diff options
| -rw-r--r-- | broadcast.py | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/broadcast.py b/broadcast.py index fe2b466..aaf1276 100644 --- a/broadcast.py +++ b/broadcast.py @@ -53,6 +53,8 @@ except IOError: exit() notestreams = iv.findall("./streams/stream[@type='ns']") +print len(notestreams), 'notestreams' +print len(clients), 'clients' class NSThread(threading.Thread): def run(self): @@ -70,7 +72,7 @@ class NSThread(threading.Thread): threads = [] for ns in notestreams: if not clients: - print 'WARNING: Out of clients!' + print 'WARNING: Out of clients!', break nsq = ns.findall('note') threads.append(NSThread(args=(nsq, clients.pop(0)))) |