Laurent/booplaysgba
1
0
Fork 0
Code Issues Pull requests Packages Projects Releases Wiki Activity

fix(emulator): updated to 3.10 asyncio

Browse source
This commit is contained in:
Laureηt 2022-02-06 17:35:30 +01:00
parent 17de7fd65c
commit 08bdca04f2
No known key found for this signature in database
GPG key ID: D88C6B294FD40994
1 changed files with 11 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
src/emulator.py
View file

@ -30,14 +30,15 @@ from settings import (
RTMP_STREAM_URI, RTMP_STREAM_URI,
) )
core = mgba.core.load_path(EMULATOR_ROM_PATH) core: mgba.core = mgba.core.load_path(EMULATOR_ROM_PATH)
screen = mgba.image.Image(EMULATOR_WIDTH, EMULATOR_HEIGHT) screen: mgba.image = mgba.image.Image(EMULATOR_WIDTH, EMULATOR_HEIGHT)
core.set_video_buffer(screen) core.set_video_buffer(screen)
core.reset() core.reset()
logging.basicConfig(level=logging.DEBUG) logging.basicConfig(level=logging.DEBUG)
mgba.log.silence() mgba.log.silence()
r = redis.Redis(host=REDIS_HOST, port=REDIS_PORT, db=0)
r: redis.Redis = redis.Redis(host=REDIS_HOST, port=REDIS_PORT, db=0)
def next_action(): def next_action():
@ -90,8 +91,7 @@ stream = Popen(
) )
def state_manager(loop): def state_manager(loop: asyncio.AbstractEventLoop):
print("ici")
ps = r.pubsub() ps = r.pubsub()
ps.subscribe("admin") ps.subscribe("admin")
while True: while True:
@ -124,7 +124,9 @@ async def emulator():
await asyncio.sleep(sleep_t) await asyncio.sleep(sleep_t)
async def main(loop): async def main():
loop = asyncio.get_event_loop()
# setup states in redis # setup states in redis
files = os.listdir("states") files = os.listdir("states")
@ -132,14 +134,14 @@ async def main(loop):
for state in states: for state in states:
r.sadd("states", state.removesuffix(".state")) # voir si oneline possible r.sadd("states", state.removesuffix(".state")) # voir si oneline possible
# launch the thread to save/load states/games
thread = threading.Thread(target=state_manager, args=(loop,)) thread = threading.Thread(target=state_manager, args=(loop,))
thread.start() thread.start()
# launch the event loop, which the emulator relies on
task_emulator = loop.create_task(emulator()) task_emulator = loop.create_task(emulator())
await task_emulator await task_emulator
if __name__ == "__main__": if __name__ == "__main__":
loop = asyncio.get_event_loop() asyncio.run(main())
loop.run_until_complete(main(loop))
loop.close()