diff options
Diffstat (limited to 'broadcast.py')
| -rw-r--r-- | broadcast.py | 242 |
1 files changed, 124 insertions, 118 deletions
diff --git a/broadcast.py b/broadcast.py index b494645..1e52f14 100644 --- a/broadcast.py +++ b/broadcast.py @@ -200,121 +200,122 @@ if options.live or options.list_live: del active_set[pitch] deferred_set.clear() -try: - iv = ET.parse(args[0]).getroot() -except IOError: +for fname in args: + try: + iv = ET.parse(fname).getroot() + except IOError: import traceback traceback.print_exc() - print 'Bad file' - exit() + print fname, ': Bad file' + continue -notestreams = iv.findall("./streams/stream[@type='ns']") -groups = set([ns.get('group') for ns in notestreams if 'group' in ns.keys()]) -print len(notestreams), 'notestreams' -print len(clients), 'clients' -print len(groups), 'groups' + notestreams = iv.findall("./streams/stream[@type='ns']") + groups = set([ns.get('group') for ns in notestreams if 'group' in ns.keys()]) + print len(notestreams), 'notestreams' + print len(clients), 'clients' + print len(groups), 'groups' -class Route(object): - def __init__(self, fattr, fvalue, group, excl=False): - if fattr == 'U': - self.map = uid_groups - elif fattr == 'T': - self.map = type_groups - else: - raise ValueError('Not a valid attribute specifier: %r'%(fattr,)) - self.value = fvalue - if group is not None and group not in groups: - raise ValueError('Not a present group: %r'%(group,)) - self.group = group - self.excl = excl - @classmethod - def Parse(cls, s): - fspecs, _, grpspecs = map(lambda x: x.strip(), s.partition('=')) - fpairs = [] - ret = [] - for fspec in [i.strip() for i in fspecs.split(',')]: - fattr, _, fvalue = map(lambda x: x.strip(), fspec.partition(':')) - fpairs.append((fattr, fvalue)) - for part in [i.strip() for i in grpspecs.split(',')]: - for fattr, fvalue in fpairs: - if part[0] == '+': - ret.append(Route(fattr, fvalue, part[1:], False)) - elif part[0] == '-': - ret.append(Route(fattr, fvalue, part[1:], True)) - elif part[0] == '0': - ret.append(Route(fattr, fvalue, None, True)) - else: - raise ValueError('Not an exclusivity: %r'%(part[0],)) - return ret - def Apply(self, cli): - return cli in self.map.get(self.value, []) - def __repr__(self): - return '<Route of %r to %s:%s>'%(self.group, ('U' if self.map is uid_groups else 'T'), self.value) + class Route(object): + def __init__(self, fattr, fvalue, group, excl=False): + if fattr == 'U': + self.map = uid_groups + elif fattr == 'T': + self.map = type_groups + else: + raise ValueError('Not a valid attribute specifier: %r'%(fattr,)) + self.value = fvalue + if group is not None and group not in groups: + raise ValueError('Not a present group: %r'%(group,)) + self.group = group + self.excl = excl + @classmethod + def Parse(cls, s): + fspecs, _, grpspecs = map(lambda x: x.strip(), s.partition('=')) + fpairs = [] + ret = [] + for fspec in [i.strip() for i in fspecs.split(',')]: + fattr, _, fvalue = map(lambda x: x.strip(), fspec.partition(':')) + fpairs.append((fattr, fvalue)) + for part in [i.strip() for i in grpspecs.split(',')]: + for fattr, fvalue in fpairs: + if part[0] == '+': + ret.append(Route(fattr, fvalue, part[1:], False)) + elif part[0] == '-': + ret.append(Route(fattr, fvalue, part[1:], True)) + elif part[0] == '0': + ret.append(Route(fattr, fvalue, None, True)) + else: + raise ValueError('Not an exclusivity: %r'%(part[0],)) + return ret + def Apply(self, cli): + return cli in self.map.get(self.value, []) + def __repr__(self): + return '<Route of %r to %s:%s>'%(self.group, ('U' if self.map is uid_groups else 'T'), self.value) -class RouteSet(object): - def __init__(self, clis=None): - if clis is None: - clis = clients[:] - self.clients = clis - self.routes = [] - def Route(self, stream): - testset = self.clients[:] - grp = stream.get('group', 'ALL') - if options.verbose: - print 'Routing', grp, '...' - excl = False - for route in self.routes: - if route.group == grp: - if options.verbose: - print '\tMatches route', route - excl = excl or route.excl - matches = filter(lambda x, route=route: route.Apply(x), testset) - if matches: + class RouteSet(object): + def __init__(self, clis=None): + if clis is None: + clis = clients[:] + self.clients = clis + self.routes = [] + def Route(self, stream): + testset = self.clients[:] + grp = stream.get('group', 'ALL') + if options.verbose: + print 'Routing', grp, '...' + excl = False + for route in self.routes: + if route.group == grp: + if options.verbose: + print '\tMatches route', route + excl = excl or route.excl + matches = filter(lambda x, route=route: route.Apply(x), testset) + if matches: + if options.verbose: + print '\tUsing client', matches[0] + self.clients.remove(matches[0]) + return matches[0] + if options.verbose: + print '\tNo matches, moving on...' + if route.group is None: if options.verbose: - print '\tUsing client', matches[0] - self.clients.remove(matches[0]) - return matches[0] + print 'Encountered NULL route, removing from search space...' + toremove = [] + for cli in testset: + if route.Apply(cli): + toremove.append(cli) + for cli in toremove: + if options.verbose: + print '\tRemoving', cli, '...' + testset.remove(cli) + if excl: if options.verbose: - print '\tNo matches, moving on...' - if route.group is None: + print '\tExclusively routed, no route matched.' + return None + if not testset: if options.verbose: - print 'Encountered NULL route, removing from search space...' - toremove = [] - for cli in testset: - if route.Apply(cli): - toremove.append(cli) - for cli in toremove: - if options.verbose: - print '\tRemoving', cli, '...' - testset.remove(cli) - if excl: - if options.verbose: - print '\tExclusively routed, no route matched.' - return None - if not testset: + print '\tOut of clients, no route matched.' + return None + cli = testset[0] + self.clients.remove(cli) if options.verbose: - print '\tOut of clients, no route matched.' - return None - cli = testset[0] - self.clients.remove(cli) - if options.verbose: - print '\tDefault route to', cli - return cli + print '\tDefault route to', cli + return cli -routeset = RouteSet() -for rspec in options.routes: - try: - routeset.routes.extend(Route.Parse(rspec)) - except Exception: - import traceback - traceback.print_exc() + routeset = RouteSet() + for rspec in options.routes: + try: + routeset.routes.extend(Route.Parse(rspec)) + except Exception: + import traceback + traceback.print_exc() -if options.verbose: - print 'All routes:' - for route in routeset.routes: - print route + if options.verbose: + print 'All routes:' + for route in routeset.routes: + print route -class NSThread(threading.Thread): + class NSThread(threading.Thread): def wait_for(self, t): if t <= 0: return @@ -333,22 +334,27 @@ class NSThread(threading.Thread): print (time.time() - BASETIME), cl, ': PLAY', pitch, dur, vel self.wait_for(dur - ((time.time() - BASETIME) - factor*ttime)) if options.verbose: - print '% 6.5f'%(time.time() - BASETIME,), cl, ': DONE' + print (time.time() - BASETIME), cl, ': PLAY', pitch, dur, vel + self.wait_for(dur - ((time.time() - BASETIME) - factor*ttime)) + if options.verbose: + print '% 6.5f'%(time.time() - BASETIME,), cl, ': DONE' -threads = [] -for ns in notestreams: - cli = routeset.Route(ns) - if cli: - nsq = ns.findall('note') - threads.append(NSThread(args=(nsq, cli))) + threads = [] + for ns in notestreams: + cli = routeset.Route(ns) + if cli: + nsq = ns.findall('note') + threads.append(NSThread(args=(nsq, cli))) -if options.verbose: - print 'Playback threads:' + if options.verbose: + print 'Playback threads:' + for thr in threads: + print thr._Thread__args[1] + + BASETIME = time.time() + for thr in threads: + thr.start() for thr in threads: - print thr._Thread__args[1] + thr.join() -BASETIME = time.time() -for thr in threads: - thr.start() -for thr in threads: - thr.join() + print fname, ': Done!' |