mirror of
https://github.com/m-labs/artiq.git
synced 2024-12-24 19:04:02 +08:00
146 lines
3.6 KiB
Python
146 lines
3.6 KiB
Python
from operator import itemgetter
|
|
import importlib.machinery
|
|
import linecache
|
|
import logging
|
|
import sys
|
|
import asyncio
|
|
import time
|
|
import collections
|
|
import os.path
|
|
|
|
from artiq.language.environment import is_experiment
|
|
from artiq.protocols import pyon
|
|
|
|
|
|
logger = logging.getLogger(__name__)
|
|
|
|
|
|
def parse_arguments(arguments):
|
|
d = {}
|
|
for argument in arguments:
|
|
name, eq, value = argument.partition("=")
|
|
d[name] = pyon.decode(value)
|
|
return d
|
|
|
|
|
|
def file_import(filename):
|
|
linecache.checkcache(filename)
|
|
|
|
modname = filename
|
|
i = modname.rfind("/")
|
|
if i > 0:
|
|
modname = modname[i+1:]
|
|
i = modname.find(".")
|
|
if i > 0:
|
|
modname = modname[:i]
|
|
modname = "file_import_" + modname
|
|
|
|
path = os.path.dirname(os.path.realpath(filename))
|
|
sys.path.insert(0, path)
|
|
|
|
loader = importlib.machinery.SourceFileLoader(modname, filename)
|
|
module = loader.load_module()
|
|
|
|
sys.path.remove(path)
|
|
|
|
return module
|
|
|
|
|
|
def get_experiment(module, experiment=None):
|
|
if experiment:
|
|
return getattr(module, experiment)
|
|
|
|
exps = [(k, v) for k, v in module.__dict__.items()
|
|
if k[0] != "_" and is_experiment(v)]
|
|
if not exps:
|
|
raise ValueError("No experiments in module")
|
|
if len(exps) > 1:
|
|
raise ValueError("More than one experiment found in module")
|
|
return exps[0][1]
|
|
|
|
|
|
def verbosity_args(parser):
|
|
group = parser.add_argument_group("verbosity")
|
|
group.add_argument("-v", "--verbose", default=0, action="count",
|
|
help="increase logging level")
|
|
group.add_argument("-q", "--quiet", default=0, action="count",
|
|
help="decrease logging level")
|
|
|
|
|
|
def simple_network_args(parser, default_port):
|
|
group = parser.add_argument_group("network")
|
|
group.add_argument("--bind", default="::1",
|
|
help="hostname or IP address to bind to")
|
|
group.add_argument("-p", "--port", default=default_port, type=int,
|
|
help="TCP port to listen to (default: %(default)d)")
|
|
|
|
|
|
def init_logger(args):
|
|
logging.basicConfig(level=logging.WARNING + args.quiet*10 - args.verbose*10)
|
|
|
|
|
|
@asyncio.coroutine
|
|
def exc_to_warning(coro):
|
|
try:
|
|
yield from coro
|
|
except:
|
|
logger.warning("asyncio coroutine terminated with exception",
|
|
exc_info=True)
|
|
|
|
|
|
@asyncio.coroutine
|
|
def asyncio_wait_or_cancel(fs, **kwargs):
|
|
fs = [asyncio.async(f) for f in fs]
|
|
try:
|
|
d, p = yield from asyncio.wait(fs, **kwargs)
|
|
except:
|
|
for f in fs:
|
|
f.cancel()
|
|
raise
|
|
for f in p:
|
|
f.cancel()
|
|
yield from asyncio.wait([f])
|
|
return fs
|
|
|
|
|
|
class TaskObject:
|
|
def start(self):
|
|
self.task = asyncio.async(self._do())
|
|
|
|
@asyncio.coroutine
|
|
def stop(self):
|
|
self.task.cancel()
|
|
try:
|
|
yield from asyncio.wait_for(self.task, None)
|
|
except asyncio.CancelledError:
|
|
pass
|
|
del self.task
|
|
|
|
@asyncio.coroutine
|
|
def _do(self):
|
|
raise NotImplementedError
|
|
|
|
|
|
class Condition:
|
|
def __init__(self, *, loop=None):
|
|
if loop is not None:
|
|
self._loop = loop
|
|
else:
|
|
self._loop = asyncio.get_event_loop()
|
|
self._waiters = collections.deque()
|
|
|
|
@asyncio.coroutine
|
|
def wait(self):
|
|
"""Wait until notified."""
|
|
fut = asyncio.Future(loop=self._loop)
|
|
self._waiters.append(fut)
|
|
try:
|
|
yield from fut
|
|
finally:
|
|
self._waiters.remove(fut)
|
|
|
|
def notify(self):
|
|
for fut in self._waiters:
|
|
if not fut.done():
|
|
fut.set_result(False)
|