broadcast.py 31 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664
  1. import socket
  2. import sys
  3. import struct
  4. import time
  5. import xml.etree.ElementTree as ET
  6. import threading
  7. import thread
  8. import optparse
  9. import random
  10. import itertools
  11. import re
  12. import os
  13. from packet import Packet, CMD, itos, OBLIGATE_POLYPHONE
  14. parser = optparse.OptionParser()
  15. parser.add_option('-t', '--test', dest='test', action='store_true', help='Play a test tone (440, 880) on all clients in sequence (the last overlaps with the first of the next)')
  16. parser.add_option('-T', '--transpose', dest='transpose', type='int', help='Transpose by a set amount of semitones (positive or negative)')
  17. parser.add_option('--sync-test', dest='sync_test', action='store_true', help='Don\'t wait for clients to play tones properly--have them all test tone at the same time')
  18. parser.add_option('--wait-test', dest='wait_test', action='store_true', help='Wait for user input before moving to the next client tested')
  19. parser.add_option('-R', '--random', dest='random', type='float', help='Generate random notes at approximately this period')
  20. parser.add_option('--rand-low', dest='rand_low', type='int', help='Low frequency to randomly sample')
  21. parser.add_option('--rand-high', dest='rand_high', type='int', help='High frequency to randomly sample')
  22. parser.add_option('-l', '--live', dest='live', help='Enter live mode (play from a controller in real time), specifying the port to connect to as "client,port"; use just "," to manually subscribe later')
  23. parser.add_option('-L', '--list-live', dest='list_live', action='store_true', help='List all the clients and ports that can be connected to for live performance')
  24. parser.add_option('--no-sustain', dest='no_sustain', action='store_true', help='Don\'t use sustain hacks in live mode')
  25. parser.add_option('-q', '--quit', dest='quit', action='store_true', help='Instruct all clients to quit')
  26. parser.add_option('-p', '--play', dest='play', action='append', help='Play a single tone or chord (specified multiple times) on all listening clients (either "midi pitch" or "@frequency")')
  27. parser.add_option('-P', '--play-async', dest='play_async', action='store_true', help='Don\'t wait for the tone to finish using the local clock')
  28. parser.add_option('-D', '--duration', dest='duration', type='float', help='How long to play this note for')
  29. parser.add_option('-V', '--volume', dest='volume', type='float', help='Master volume [0.0, 1.0]')
  30. parser.add_option('-s', '--silence', dest='silence', action='store_true', help='Instruct all clients to stop playing any active tones')
  31. parser.add_option('-S', '--seek', dest='seek', type='float', help='Start time in seconds (scaled by --factor)')
  32. parser.add_option('-f', '--factor', dest='factor', type='float', help='Rescale time by this factor (0<f<1 are faster; 0.5 is twice the speed, 2 is half)')
  33. parser.add_option('-r', '--route', dest='routes', action='append', help='Add a routing directive (see --route-help)')
  34. parser.add_option('-v', '--verbose', dest='verbose', action='store_true', help='Be verbose; dump events and actual time (can slow down performance!)')
  35. parser.add_option('-W', '--wait-time', dest='wait_time', type='float', help='How long to wait between pings for clients to initially respond (delays all broadcasts)')
  36. parser.add_option('--tries', dest='tries', type='int', help='Number of ping packets to send')
  37. parser.add_option('-B', '--bind-addr', dest='bind_addr', help='The IP address (or IP:port) to bind to (influences the network to send to)')
  38. parser.add_option('--port', dest='ports', action='append', type='int', help='Add a port to find clients on')
  39. parser.add_option('--clear-ports', dest='ports', action='store_const', const=[], help='Clear ports previously specified (including the default)')
  40. parser.add_option('--repeat', dest='repeat', action='store_true', help='Repeat the file playlist indefinitely')
  41. parser.add_option('-n', '--number', dest='number', type='int', help='Number of clients to use; if negative (default -1), use the product of stream count and the absolute value of this parameter')
  42. parser.add_option('--dry', dest='dry', action='store_true', help='Dry run--don\'t actually search for or play to clients, but pretend they exist (useful with -G)')
  43. parser.add_option('--pcm', dest='pcm', action='store_true', help='Use experimental PCM rendering')
  44. parser.add_option('--pcm-lead', dest='pcmlead', type='float', help='Seconds of leading PCM data to send')
  45. parser.add_option('--spin', dest='spin', action='store_true', help='Ignore delta times in the queue (busy loop the CPU) for higher accuracy')
  46. parser.add_option('-G', '--gui', dest='gui', default='', help='set a GUI to use')
  47. parser.add_option('--pg-fullscreen', dest='fullscreen', action='store_true', help='Use a full-screen video mode')
  48. parser.add_option('--pg-width', dest='pg_width', type='int', help='Width of the pygame window')
  49. parser.add_option('--pg-height', dest='pg_height', type='int', help='Width of the pygame window')
  50. parser.add_option('--help-routes', dest='help_routes', action='store_true', help='Show help about routing directives')
  51. parser.set_defaults(routes=[], random=0.0, rand_low=80, rand_high=2000, live=None, factor=1.0, duration=0.25, volume=1.0, wait_time=0.1, tries=5, play=[], transpose=0, seek=0.0, bind_addr='', ports=[13676], pg_width = 0, pg_height = 0, number=-1, pcmlead=0.1)
  52. options, args = parser.parse_args()
  53. if options.help_routes:
  54. print '''Routes are a way of either exclusively or mutually binding certain streams to certain playback clients. They are especially fitting in heterogenous environments where some clients will outperform others in certain pitches or with certain parts.
  55. Routes are fully specified by:
  56. -The attribute to be routed on (either type "T", or UID "U")
  57. -The value of that attribute
  58. -The exclusivity of that route ("+" for inclusive, "-" for exclusive, "!" for complete)
  59. -The stream group to be routed there, or 0 to null route.
  60. The first two may be replaced by a single '0' to null route a stream--effective only when used with an exclusive route.
  61. "Complete" exclusivity is valid only for obligate polyphones, and indicates that *all* matches are to receive the stream. In other cases, this will have the undesirable effect of routing only one stream.
  62. The special group ALL matches all streams. Regular expressions may be used to specify groups. Note that the first character is *not* part of the regular expression.
  63. The syntax for that specification resembles the following:
  64. broadcast.py -r U:bass=+bass -r U:treble1,U:treble2=+treble -r T:BEEP=-beeps,-trk3,-trk5 -r U:noise=0
  65. The specifier consists of a comma-separated list of attribute-colon-value pairs, followed by an equal sign. After this is a comma-separated list of exclusivities paired with the name of a stream group as specified in the file. The above example shows that stream groups "bass", "treble", and "beeps" will be routed to clients with UID "bass", "treble", and TYPE "BEEP" respectively. Additionally, TYPE "BEEP" will receive tracks 4 and 6 (indices 3 and 5) of the MIDI file (presumably split with -T), and that these three groups are exclusively to be routed to TYPE "BEEP" clients only (the broadcaster will drop the stream if no more are available), as opposed to the preference of the bass and treble groups, which may be routed onto other stream clients if they are available. Finally, the last route says that all "noise" UID clients should not proceed any further (receiving "null" streams) instead. Order is important; if a "noise" client already received a stream (such as "+beeps"), then it would receive that route with priority.'''
  66. exit()
  67. GUIS = {}
  68. BASETIME = time.time() # XXX fixes a race with the GUI
  69. def gui_pygame():
  70. print 'Starting pygame GUI...'
  71. import pygame, colorsys
  72. pygame.init()
  73. print 'Pygame init'
  74. dispinfo = pygame.display.Info()
  75. DISP_WIDTH = 640
  76. DISP_HEIGHT = 480
  77. if dispinfo.current_h > 0 and dispinfo.current_w > 0:
  78. DISP_WIDTH = dispinfo.current_w
  79. DISP_HEIGHT = dispinfo.current_h
  80. print 'Pygame info'
  81. WIDTH = DISP_WIDTH
  82. if options.pg_width > 0:
  83. WIDTH = options.pg_width
  84. HEIGHT = DISP_HEIGHT
  85. if options.pg_height > 0:
  86. HEIGHT = options.pg_height
  87. flags = 0
  88. if options.fullscreen:
  89. flags |= pygame.FULLSCREEN
  90. disp = pygame.display.set_mode((WIDTH, HEIGHT), flags)
  91. print 'Disp acquire'
  92. PFAC = HEIGHT / 128.0
  93. clock = pygame.time.Clock()
  94. font = pygame.font.SysFont(pygame.font.get_default_font(), 24)
  95. print 'Pygame GUI initialized, running...'
  96. while True:
  97. disp.scroll(-1, 0)
  98. disp.fill((0, 0, 0), (WIDTH - 1, 0, 1, HEIGHT))
  99. idx = 0
  100. for cli, note in sorted(playing_notes.items(), key = lambda pair: pair[0]):
  101. pitch = note[0]
  102. col = colorsys.hls_to_rgb(float(idx) / len(targets), note[1]/2.0, 1.0)
  103. col = [int(i*255) for i in col]
  104. disp.fill(col, (WIDTH - 1, HEIGHT - pitch * PFAC - PFAC, 1, PFAC))
  105. idx += 1
  106. tsurf = font.render('%0.3f' % ((time.time() - BASETIME) / factor,), True, (255, 255, 255), (0, 0, 0))
  107. disp.fill((0, 0, 0), tsurf.get_rect())
  108. disp.blit(tsurf, (0, 0))
  109. pygame.display.flip()
  110. for ev in pygame.event.get():
  111. if ev.type == pygame.KEYDOWN:
  112. if ev.key == pygame.K_ESCAPE:
  113. thread.interrupt_main()
  114. pygame.quit()
  115. exit()
  116. clock.tick(60)
  117. GUIS['pygame'] = gui_pygame
  118. factor = options.factor
  119. print 'Factor:', factor
  120. try:
  121. rows, columns = map(int, os.popen('stty size', 'r').read().split())
  122. except Exception:
  123. import traceback
  124. traceback.print_exc()
  125. rows, columns = 25, 80
  126. s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
  127. s.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1)
  128. if options.bind_addr:
  129. addr, _, port = options.bind_addr.partition(':')
  130. if not port:
  131. port = '12074'
  132. s.bind((addr, int(port)))
  133. clients = set()
  134. targets = set()
  135. uid_groups = {}
  136. type_groups = {}
  137. ports = {}
  138. if not options.dry:
  139. s.settimeout(options.wait_time)
  140. for PORT in options.ports:
  141. for num in xrange(options.tries):
  142. s.sendto(str(Packet(CMD.PING)), ('255.255.255.255', PORT))
  143. try:
  144. while True:
  145. data, src = s.recvfrom(4096)
  146. clients.add(src)
  147. except socket.timeout:
  148. pass
  149. print len(clients), 'detected clients'
  150. for num in xrange(options.tries):
  151. print 'Try', num
  152. for cl in clients:
  153. print cl,
  154. s.sendto(str(Packet(CMD.CAPS)), cl)
  155. data, _ = s.recvfrom(4096)
  156. pkt = Packet.FromStr(data)
  157. print 'ports', pkt.data[0],
  158. ports[cl] = pkt.data[0]
  159. tp = itos(pkt.data[1])
  160. print 'type', tp,
  161. uid = ''.join([itos(i) for i in pkt.data[2:]]).rstrip('\x00')
  162. print 'uid', uid
  163. if uid == '':
  164. uid = None
  165. uid_groups.setdefault(uid, set()).add(cl)
  166. type_groups.setdefault(tp, set()).add(cl)
  167. if options.test:
  168. ts, tms = int(options.duration), int(options.duration * 1000000) % 1000000
  169. if options.wait_test:
  170. s.sendto(str(Packet(CMD.PLAY, 65535, 0, 440, options.volume)), cl)
  171. raw_input('%r: Press enter to test next client...' %(cl,))
  172. s.sendto(str(Packet(CMD.PLAY, ts, tms, 880, options.volume)), cl)
  173. else:
  174. s.sendto(str(Packet(CMD.PLAY, ts, tms, 440, options.volume)), cl)
  175. if not options.sync_test:
  176. time.sleep(options.duration)
  177. s.sendto(str(Packet(CMD.PLAY, ts, tms, 880, options.volume)), cl)
  178. if options.quit:
  179. s.sendto(str(Packet(CMD.QUIT)), cl)
  180. if options.silence:
  181. for i in xrange(pkt.data[0]):
  182. s.sendto(str(Packet(CMD.PLAY, 0, 1, 1, 0.0, i)), cl)
  183. if pkt.data[0] == OBLIGATE_POLYPHONE:
  184. pkt.data[0] = 1
  185. for i in xrange(pkt.data[0]):
  186. targets.add(cl+(i,))
  187. playing_notes = {}
  188. for tg in targets:
  189. playing_notes[tg] = (0, 0)
  190. if options.gui:
  191. gui_thr = threading.Thread(target=GUIS[options.gui], args=())
  192. gui_thr.setDaemon(True)
  193. gui_thr.start()
  194. if options.play:
  195. for i, val in enumerate(options.play):
  196. if val.startswith('@'):
  197. options.play[i] = int(val[1:])
  198. else:
  199. options.play[i] = int(440.0 * 2**((int(val) - 69)/12.0))
  200. for i, cl in enumerate(targets):
  201. s.sendto(str(Packet(CMD.PLAY, int(options.duration), int(1000000*(options.duration-int(options.duration))), options.play[i%len(options.play)], options.volume, cl[2])), cl[:2])
  202. if not options.play_async:
  203. time.sleep(options.duration)
  204. exit()
  205. if options.test and options.sync_test:
  206. time.sleep(0.25)
  207. for cl in targets:
  208. s.sendto(str(Packet(CMD.PLAY, 0, 250000, 880, options.volume, cl[2])), cl[:2])
  209. if options.test or options.quit or options.silence:
  210. print uid_groups
  211. print type_groups
  212. exit()
  213. if options.random > 0:
  214. while True:
  215. for cl in targets:
  216. s.sendto(str(Packet(CMD.PLAY, int(options.random), int(1000000*(options.random-int(options.random))), random.randint(options.rand_low, options.rand_high), options.volume, cl[2])), cl[:2])
  217. time.sleep(options.random)
  218. if options.live or options.list_live:
  219. if options.gui:
  220. print 'Waiting a second for GUI init...'
  221. time.sleep(3.0)
  222. import midi
  223. from midi import sequencer
  224. S = sequencer.S
  225. if options.list_live:
  226. print sequencer.SequencerHardware()
  227. exit()
  228. seq = sequencer.SequencerRead(sequencer_resolution=120)
  229. client_set = set(targets)
  230. active_set = {} # note (pitch) -> [client]
  231. deferred_set = set() # pitches held due to sustain
  232. sustain_status = False
  233. client, _, port = options.live.partition(',')
  234. if client or port:
  235. seq.subscribe_port(client, port)
  236. seq.start_sequencer()
  237. if not options.gui: # FIXME
  238. seq.set_nonblock(False)
  239. while True:
  240. ev = S.event_input(seq.client)
  241. if ev is None:
  242. time.sleep(0)
  243. event = None
  244. if ev:
  245. if options.verbose:
  246. print 'SEQ:', ev
  247. if ev < 0:
  248. seq._error(ev)
  249. if ev.type == S.SND_SEQ_EVENT_NOTEON:
  250. event = midi.NoteOnEvent(channel = ev.data.note.channel, pitch = ev.data.note.note, velocity = ev.data.note.velocity)
  251. elif ev.type == S.SND_SEQ_EVENT_NOTEOFF:
  252. event = midi.NoteOffEvent(channel = ev.data.note.channel, pitch = ev.data.note.note, velocity = ev.data.note.velocity)
  253. elif ev.type == S.SND_SEQ_EVENT_CONTROLLER:
  254. event = midi.ControlChangeEvent(channel = ev.data.control.channel, control = ev.data.control.param, value = ev.data.control.value)
  255. elif ev.type == S.SND_SEQ_EVENT_PGMCHANGE:
  256. event = midi.ProgramChangeEvent(channel = ev.data.control.channel, value = ev.data.control.value)
  257. elif ev.type == S.SND_SEQ_EVENT_PITCHBEND:
  258. event = midi.PitchWheelEvent(channel = ev.data.control.channel, pitch = ev.data.control.value)
  259. elif options.verbose:
  260. print 'WARNING: Unparsed event, type %r'%(ev.type,)
  261. continue
  262. if event is not None:
  263. if isinstance(event, midi.NoteOnEvent) and event.velocity == 0:
  264. event.__class__ = midi.NoteOffEvent
  265. if options.verbose:
  266. print 'EVENT:', event
  267. if isinstance(event, midi.NoteOnEvent):
  268. if event.pitch in active_set:
  269. if sustain_status:
  270. deferred_set.discard(event.pitch)
  271. inactive_set = client_set - set(sum(active_set.values(), []))
  272. if not inactive_set:
  273. print 'WARNING: Out of clients to do note %r; dropped'%(event.pitch,)
  274. continue
  275. cli = sorted(inactive_set)[0]
  276. s.sendto(str(Packet(CMD.PLAY, 65535, 0, int(440.0 * 2**((event.pitch-69)/12.0)), event.velocity / 127.0, cli[2])), cli[:2])
  277. active_set.setdefault(event.pitch, []).append(cli)
  278. playing_notes[cli] = (event.pitch, event.velocity / 127.0)
  279. if options.verbose:
  280. print 'LIVE:', event.pitch, '+ =>', active_set[event.pitch]
  281. elif isinstance(event, midi.NoteOffEvent):
  282. if event.pitch not in active_set or not active_set[event.pitch]:
  283. print 'WARNING: Deactivating inactive note %r'%(event.pitch,)
  284. continue
  285. if sustain_status:
  286. deferred_set.add(event.pitch)
  287. continue
  288. cli = active_set[event.pitch].pop()
  289. s.sendto(str(Packet(CMD.PLAY, 0, 1, 1, 0, cli[2])), cli[:2])
  290. playing_notes[cli] = (0, 0)
  291. if options.verbose:
  292. print 'LIVE:', event.pitch, '- =>', active_set[event.pitch]
  293. if sustain_status:
  294. print '...ignored (sustain on)'
  295. elif isinstance(event, midi.ControlChangeEvent):
  296. if event.control == 64 and not options.no_sustain:
  297. sustain_status = (event.value >= 64)
  298. if options.verbose:
  299. print 'LIVE: SUSTAIN', ('+' if sustain_status else '-')
  300. if not sustain_status:
  301. for pitch in deferred_set:
  302. if pitch not in active_set or not active_set[pitch]:
  303. print 'WARNING: Attempted deferred removal of inactive note %r'%(pitch,)
  304. continue
  305. for cli in active_set[pitch]:
  306. s.sendto(str(Packet(CMD.PLAY, 0, 1, 1, 0, cli[2])), cli[:2])
  307. playing_notes[cli] = (0, 0)
  308. del active_set[pitch]
  309. deferred_set.clear()
  310. if options.repeat:
  311. args = itertools.cycle(args)
  312. for fname in args:
  313. if options.pcm and not fname.endswith('.iv'):
  314. print 'PCM: play', fname
  315. if fname == '-':
  316. import wave
  317. pcr = wave.open(sys.stdin)
  318. samprate = pcr.getframerate()
  319. pcr.read = pcr.readframes
  320. else:
  321. try:
  322. import audiotools
  323. pcr = audiotools.open(fname).to_pcm()
  324. assert pcr.channels == 1 and pcr.bits_per_sample == 16 and pcr.sample_rate == 44100
  325. samprate = pcr.sample_rate
  326. except ImportError:
  327. import wave
  328. pcr = wave.open(fname, 'r')
  329. assert pcr.getnchannels() == 1 and pcr.getsampwidth() == 2 and pcr.getframerate() == 44100
  330. samprate = pcr.getframerate()
  331. pcr.read = pcr.readframes
  332. def read_all(fn, n):
  333. buf = ''
  334. while len(buf) < n:
  335. nbuf = fn.read(n - len(buf))
  336. if not isinstance(nbuf, str):
  337. nbuf = nbuf.to_bytes(False, True)
  338. buf += nbuf
  339. return buf
  340. BASETIME = time.time() - options.pcmlead
  341. sampcnt = 0
  342. buf = read_all(pcr, 32)
  343. print 'PCM: pcr', pcr, 'BASETIME', BASETIME, 'buf', len(buf)
  344. while len(buf) >= 32:
  345. frag = buf[:32]
  346. buf = buf[32:]
  347. for cl in clients:
  348. s.sendto(struct.pack('>L', CMD.PCM) + frag, cl)
  349. sampcnt += len(frag) / 2
  350. delay = max(0, BASETIME + (sampcnt / float(samprate)) - time.time())
  351. #print sampcnt, delay
  352. if delay > 0:
  353. time.sleep(delay)
  354. if len(buf) < 32:
  355. buf += read_all(pcr, 32 - len(buf))
  356. print 'PCM: exit'
  357. continue
  358. try:
  359. iv = ET.parse(fname).getroot()
  360. except IOError:
  361. import traceback
  362. traceback.print_exc()
  363. print fname, ': Bad file'
  364. continue
  365. notestreams = iv.findall("./streams/stream[@type='ns']")
  366. groups = set([ns.get('group') for ns in notestreams if 'group' in ns.keys()])
  367. number = (len(notestreams) * abs(options.number) if options.number < 0 else options.number)
  368. print len(notestreams), 'notestreams'
  369. print len(clients), 'clients'
  370. print len(targets), 'targets'
  371. print len(groups), 'groups'
  372. print number, 'clients used (number)'
  373. class Route(object):
  374. def __init__(self, fattr, fvalue, group, excl=False, complete=False):
  375. if fattr == 'U':
  376. self.map = uid_groups
  377. elif fattr == 'T':
  378. self.map = type_groups
  379. elif fattr == '0':
  380. self.map = {}
  381. else:
  382. raise ValueError('Not a valid attribute specifier: %r'%(fattr,))
  383. self.value = fvalue
  384. self.group = group
  385. self.excl = excl
  386. self.complete = complete
  387. @classmethod
  388. def Parse(cls, s):
  389. fspecs, _, grpspecs = map(lambda x: x.strip(), s.partition('='))
  390. fpairs = []
  391. ret = []
  392. for fspec in [i.strip() for i in fspecs.split(',')]:
  393. fattr, _, fvalue = map(lambda x: x.strip(), fspec.partition(':'))
  394. fpairs.append((fattr, fvalue))
  395. for part in [i.strip() for i in grpspecs.split(',')]:
  396. for fattr, fvalue in fpairs:
  397. if part[0] == '+':
  398. ret.append(Route(fattr, fvalue, part[1:], False))
  399. elif part[0] == '-':
  400. ret.append(Route(fattr, fvalue, part[1:], True))
  401. elif part[0] == '!':
  402. ret.append(Route(fattr, fvalue, part[1:], True, True))
  403. elif part[0] == '0':
  404. ret.append(Route(fattr, fvalue, None, True))
  405. else:
  406. raise ValueError('Not an exclusivity: %r'%(part[0],))
  407. return ret
  408. def Apply(self, cli):
  409. return cli[:2] in self.map.get(self.value, [])
  410. def __repr__(self):
  411. return '<Route of %r to %s:%s>'%(self.group, ('U' if self.map is uid_groups else 'T'), self.value)
  412. class RouteSet(object):
  413. def __init__(self, clis=None):
  414. if clis is None:
  415. clis = set(targets)
  416. self.clients = list(clis)
  417. self.routes = []
  418. def Route(self, stream):
  419. testset = self.clients
  420. grp = stream.get('group', 'ALL')
  421. if options.verbose:
  422. print 'Routing', grp, '...'
  423. excl = False
  424. for route in self.routes:
  425. if route.group is not None and re.match(route.group, grp) is not None:
  426. if options.verbose:
  427. print '\tMatches route', route
  428. excl = excl or route.excl
  429. matches = filter(lambda x, route=route: route.Apply(x), testset)
  430. if matches:
  431. if route.complete:
  432. if options.verbose:
  433. print '\tUsing ALL clients:', matches
  434. for cl in matches:
  435. self.clients.remove(matches[0])
  436. if ports.get(matches[0][:2]) == OBLIGATE_POLYPHONE:
  437. self.clients.append(matches[0])
  438. return matches
  439. if options.verbose:
  440. print '\tUsing client', matches[0]
  441. self.clients.remove(matches[0])
  442. if ports.get(matches[0][:2]) == OBLIGATE_POLYPHONE:
  443. self.clients.append(matches[0])
  444. return [matches[0]]
  445. if options.verbose:
  446. print '\tNo matches, moving on...'
  447. if route.group is None:
  448. if options.verbose:
  449. print 'Encountered NULL route, removing from search space...'
  450. toremove = []
  451. for cli in testset:
  452. if route.Apply(cli):
  453. toremove.append(cli)
  454. for cli in toremove:
  455. if options.verbose:
  456. print '\tRemoving', cli, '...'
  457. testset.remove(cli)
  458. if excl:
  459. if options.verbose:
  460. print '\tExclusively routed, no route matched.'
  461. return []
  462. if not testset:
  463. if options.verbose:
  464. print '\tOut of clients, no route matched.'
  465. return []
  466. cli = list(testset)[0]
  467. self.clients.remove(cli)
  468. if ports.get(cli[:2]) == OBLIGATE_POLYPHONE:
  469. self.clients.append(cli)
  470. if options.verbose:
  471. print '\tDefault route to', cli
  472. return [cli]
  473. routeset = RouteSet()
  474. for rspec in options.routes:
  475. try:
  476. routeset.routes.extend(Route.Parse(rspec))
  477. except Exception:
  478. import traceback
  479. traceback.print_exc()
  480. if options.verbose:
  481. print 'All routes:'
  482. for route in routeset.routes:
  483. print route
  484. class NSThread(threading.Thread):
  485. def __init__(self, *args, **kwargs):
  486. threading.Thread.__init__(self, *args, **kwargs)
  487. self.done = False
  488. self.cur_offt = None
  489. self.next_t = None
  490. def actuate_missed(self):
  491. nsq, cls = self._Thread__args
  492. dur = None
  493. i = 0
  494. while nsq and float(nsq[0].get('time'))*factor <= time.time() - BASETIME:
  495. i += 1
  496. note = nsq.pop(0)
  497. ttime = float(note.get('time'))
  498. pitch = float(note.get('pitch')) + options.transpose
  499. ampl = float(note.get('ampl', float(note.get('vel', 127.0)) / 127.0))
  500. dur = factor*float(note.get('dur'))
  501. if options.verbose:
  502. print (time.time() - BASETIME) / options.factor, ': PLAY', pitch, dur, ampl
  503. if options.dry:
  504. playing_notes[self.nsid] = (pitch, ampl)
  505. else:
  506. for cl in cls:
  507. s.sendto(str(Packet(CMD.PLAY, int(dur), int((dur*1000000)%1000000), int(440.0 * 2**((pitch-69)/12.0)), ampl * options.volume, cl[2])), cl[:2])
  508. playing_notes[cl] = (pitch, ampl)
  509. if i > 0 and dur is not None:
  510. self.cur_offt = ttime + dur / options.factor
  511. else:
  512. if self.cur_offt:
  513. if factor * self.cur_offt <= time.time() - BASETIME:
  514. if options.verbose:
  515. print '% 6.5f'%((time.time() - BASETIME) / factor,), ': DONE'
  516. self.cur_offt = None
  517. if options.dry:
  518. playing_notes[self.nsid] = (0, 0)
  519. else:
  520. for cl in cls:
  521. playing_notes[cl] = (0, 0)
  522. next_act = None
  523. if nsq:
  524. next_act = float(nsq[0].get('time'))
  525. if options.verbose:
  526. print 'NEXT_ACT:', next_act, 'CUR_OFFT:', self.cur_offt
  527. self.next_t = min((next_act or float('inf'), self.cur_offt or float('inf')))
  528. self.done = not (nsq or self.cur_offt)
  529. def drop_missed(self):
  530. nsq, cl = self._Thread__args
  531. cnt = 0
  532. while nsq and float(nsq[0].get('time'))*factor < time.time() - BASETIME:
  533. nsq.pop(0)
  534. cnt += 1
  535. if options.verbose:
  536. print self, 'dropped', cnt, 'notes due to miss'
  537. def wait_for(self, t):
  538. if t <= 0:
  539. return
  540. time.sleep(t)
  541. def run(self):
  542. nsq, cls = self._Thread__args
  543. for note in nsq:
  544. ttime = float(note.get('time'))
  545. pitch = float(note.get('pitch')) + options.transpose
  546. ampl = float(note.get('ampl', float(note.get('vel', 127.0)) / 127.0))
  547. dur = factor*float(note.get('dur'))
  548. while time.time() - BASETIME < factor*ttime:
  549. self.wait_for(factor*ttime - (time.time() - BASETIME))
  550. if options.dry:
  551. cl = self.nsid # XXX hack
  552. else:
  553. for cl in cls:
  554. s.sendto(str(Packet(CMD.PLAY, int(dur), int((dur*1000000)%1000000), int(440.0 * 2**((pitch-69)/12.0)), ampl * options.volume, cl[2])), cl[:2])
  555. if options.verbose:
  556. print (time.time() - BASETIME), cl, ': PLAY', pitch, dur, vel
  557. playing_notes[cl] = (pitch, ampl)
  558. self.wait_for(dur - ((time.time() - BASETIME) - factor*ttime))
  559. playing_notes[cl] = (0, 0)
  560. if options.verbose:
  561. print '% 6.5f'%(time.time() - BASETIME,), cl, ': DONE'
  562. threads = {}
  563. if options.dry:
  564. for nsid, ns in enumerate(notestreams):
  565. nsq = ns.findall('note')
  566. nsq.sort(key=lambda x: float(x.get('time')))
  567. threads[ns] = NSThread(args=(nsq, set()))
  568. threads[ns].nsid = nsid
  569. targets = threads.values() # XXX hack
  570. else:
  571. nscycle = itertools.cycle(notestreams)
  572. for idx, ns in zip(xrange(number), nscycle):
  573. clis = routeset.Route(ns)
  574. for cli in clis:
  575. nsq = ns.findall('note')
  576. nsq.sort(key=lambda x: float(x.get('time')))
  577. if ns in threads:
  578. threads[ns]._Thread__args[1].add(cli)
  579. else:
  580. threads[ns] = NSThread(args=(nsq, set([cli])))
  581. if options.verbose:
  582. print 'Playback threads:'
  583. for thr in threads.values():
  584. print thr._Thread__args[1]
  585. BASETIME = time.time() - (options.seek*factor)
  586. ENDTIME = max(max(float(n.get('time')) + float(n.get('dur')) for n in thr._Thread__args[0]) for thr in threads.values())
  587. print 'Playtime is', ENDTIME
  588. if options.seek > 0:
  589. for thr in threads.values():
  590. thr.drop_missed()
  591. spin_phase = 0
  592. SPINNERS = ['-', '\\', '|', '/']
  593. while not all(thr.done for thr in threads.values()):
  594. for thr in threads.values():
  595. if thr.next_t is None or factor * thr.next_t <= time.time() - BASETIME:
  596. thr.actuate_missed()
  597. delta = factor * min(thr.next_t for thr in threads.values() if thr.next_t is not None) + BASETIME - time.time()
  598. if delta == float('inf'):
  599. print 'WARNING: Infinite postponement detected! Did all notestreams finish?'
  600. break
  601. if options.verbose:
  602. print 'TICK DELTA:', delta
  603. else:
  604. sys.stdout.write('\x1b[G\x1b[K[%s]' % (
  605. ('#' * int((time.time() - BASETIME) * (columns - 2) / (ENDTIME * factor)) + SPINNERS[spin_phase]).ljust(columns - 2),
  606. ))
  607. sys.stdout.flush()
  608. spin_phase += 1
  609. if spin_phase >= len(SPINNERS):
  610. spin_phase = 0
  611. if delta >= 0 and not options.spin:
  612. time.sleep(delta)
  613. print fname, ': Done!'