forked from M-Labs/artiq
asyncio: Use ProactorEventLoop on Windows
This commit is contained in:
parent
78fc5a8a71
commit
fc92a66e51
|
@ -3,6 +3,7 @@
|
||||||
import asyncio
|
import asyncio
|
||||||
import argparse
|
import argparse
|
||||||
import atexit
|
import atexit
|
||||||
|
import os
|
||||||
|
|
||||||
from artiq.protocols.pc_rpc import Server
|
from artiq.protocols.pc_rpc import Server
|
||||||
from artiq.protocols.sync_struct import Publisher
|
from artiq.protocols.sync_struct import Publisher
|
||||||
|
@ -40,7 +41,11 @@ def main():
|
||||||
repository = Repository()
|
repository = Repository()
|
||||||
explist = FlatFileDB("explist.pyon")
|
explist = FlatFileDB("explist.pyon")
|
||||||
|
|
||||||
loop = asyncio.get_event_loop()
|
if os.name == 'nt':
|
||||||
|
loop = asyncio.ProactorEventLoop()
|
||||||
|
asyncio.set_event_loop(loop)
|
||||||
|
else:
|
||||||
|
loop = asyncio.get_event_loop()
|
||||||
atexit.register(lambda: loop.close())
|
atexit.register(lambda: loop.close())
|
||||||
|
|
||||||
def run_cb(rid, run_params):
|
def run_cb(rid, run_params):
|
||||||
|
|
Loading…
Reference in New Issue