1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
|
import socket
import sys
import struct
import time
import xml.etree.ElementTree as ET
import threading
import optparse
from packet import Packet, CMD, itos
parser = optparse.OptionParser()
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)')
parser.add_option('-q', '--quit', dest='quit', action='store_true', help='Instruct all clients to quit')
parser.add_option('-f', '--factor', dest='factor', type='int', help='Rescale time by this factor (0<f<1 are faster; 0.5 is twice the speed, 2 is half)')
parser.add_option('-r', '--route', dest='routes', action='append', help='Add a routing directive (see --route-help)')
parser.add_option('--help-routes', dest='help_routes', action='store_true', help='Show help about routing directives')
parser.set_defaults(routes=[])
options, args = parser.parse_args()
if options.help_routes:
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.
Routes are fully specified by:
-The attribute to be routed on (either type "T", or UID "U")
-The value of that attribute
-The exclusivity of that route ("+" for inclusive, "-" for exclusive)
-The stream group to be routed there.
The syntax for that specification resembles the following:
broadcast.py -r U:bass=+bass -r U:treble1,U:treble2=+treble -r T:BEEP=-beeps,-trk3,-trk5
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.'''
exit()
PORT = 13676
if len(sys.argv) > 2:
factor = float(sys.argv[2])
else:
factor = 1
print 'Factor:', factor
s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
s.setsockopt(socket.SOL_SOCKET, socket.SO_BROADCAST, 1)
clients = []
uid_groups = {}
type_groups = {}
s.sendto(str(Packet(CMD.PING)), ('255.255.255.255', PORT))
s.settimeout(0.5)
try:
while True:
data, src = s.recvfrom(4096)
clients.append(src)
except socket.timeout:
pass
print 'Clients:'
for cl in clients:
print cl,
s.sendto(str(Packet(CMD.CAPS)), cl)
data, _ = s.recvfrom(4096)
pkt = Packet.FromStr(data)
print 'ports', pkt.data[0],
tp = itos(pkt.data[1])
print 'type', tp,
uid = ''.join([itos(i) for i in pkt.data[2:]]).rstrip('\x00')
print 'uid', uid
if uid == '':
uid = None
uid_groups.setdefault(uid, []).append(cl)
type_groups.setdefault(tp, []).append(cl)
if options.test:
s.sendto(str(Packet(CMD.PLAY, 0, 250000, 440, 255)), cl)
time.sleep(0.25)
s.sendto(str(Packet(CMD.PLAY, 0, 250000, 880, 255)), cl)
if options.quit:
s.sendto(str(Packet(CMD.QUIT)), cl)
if options.test or options.quit:
print uid_groups
print type_groups
exit()
try:
iv = ET.parse(sys.argv[1]).getroot()
except IOError:
print 'Bad file'
exit()
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 NSThread(threading.Thread):
def run(self):
nsq, cl = self._Thread__args
for note in nsq:
ttime = float(note.get('time'))
pitch = int(note.get('pitch'))
vel = int(note.get('vel'))
dur = factor*float(note.get('dur'))
while time.time() - BASETIME < factor*ttime:
time.sleep(factor*ttime - (time.time() - BASETIME))
s.sendto(str(Packet(CMD.PLAY, int(dur), int((dur*1000000)%1000000), int(440.0 * 2**((pitch-69)/12.0)), vel*2)), cl)
time.sleep(dur)
threads = []
for ns in notestreams:
if not clients:
print 'WARNING: Out of clients!',
break
nsq = ns.findall('note')
threads.append(NSThread(args=(nsq, clients.pop(0))))
BASETIME = time.time()
for thr in threads:
thr.start()
for thr in threads:
thr.join()
|
