Mercurial > code > home > repos > light9
annotate light8/io.py @ 71:177e9ba0b4a7
simple DMX server
| author | dmcc |
|---|---|
| date | Thu, 11 Jul 2002 09:33:02 +0000 |
| parents | 032b2b67bc10 |
| children | 609cb9ae53b1 |
| rev | line source |
|---|---|
| 16 | 1 from parport import * |
| 71 | 2 import socket, os |
| 3 | |
| 4 lastlevels = {} | |
| 5 | |
| 6 def gethostlist(host): | |
| 7 return lastlevels[host] | |
| 8 | |
| 9 def parselist(levels): | |
| 10 newlist = [0] * 68 | |
| 11 # levels has at least one pair | |
| 12 ch, lev = None, None | |
| 13 while len(levels) >= 2: | |
| 14 ch, lev = levels.pop(0), levels.pop(0) | |
| 15 | |
| 16 # off by one errors -- i hate them sooo much | |
| 17 newlist[int(ch) - 1] = int(lev) | |
| 18 return newlist | |
| 19 | |
| 20 def sethostlist(host, changes): | |
| 21 if not changes: return | |
| 22 global lastlevels | |
| 23 if host not in lastlevels: | |
| 24 lastlevels[host] = [0] * 68 | |
| 0 | 25 |
| 71 | 26 lastlevels[host] = parselist(changes) |
| 27 ''' | |
| 28 # changes has at least one pair | |
| 29 ch, lev = None, None | |
| 30 while len(changes) >= 2: | |
| 31 ch, lev = changes.pop(0), changes.pop(0) | |
| 32 | |
| 33 # off by one errors -- i hate them sooo much | |
| 34 lastlevels[host][ch - 1] = lev | |
| 35 ''' | |
| 36 | |
| 37 | |
| 38 def sendlevels(levels): | |
| 39 print "sendlevels: i'm a level hobo:", levels | |
| 40 levels = levels + [0] | |
| 41 # if levels[14] > 0: levels[14] = 100 # non-dim | |
| 42 print "sendlevels: wait for it... length =", len(levels) | |
| 43 outstart() | |
| 44 for p in range(1, 68 + 2): | |
| 45 outbyte(levels[p-1]*255 / 100) | |
| 46 print "sendlevels: done" | |
| 47 | |
| 48 class ParportDMX: # ethdmx client or standalone server | |
| 49 def __init__(self, dummy=1, dimmers=68, machine_name='localhost', | |
| 50 standalone=0): | |
| 53 | 51 self.dimmers = dimmers |
|
29
f595fdd4c548
minor cleanups, convert parallel port controller to a class
dmcc
parents:
16
diff
changeset
|
52 self.dummy = dummy |
|
f595fdd4c548
minor cleanups, convert parallel port controller to a class
dmcc
parents:
16
diff
changeset
|
53 if not dummy: |
|
f595fdd4c548
minor cleanups, convert parallel port controller to a class
dmcc
parents:
16
diff
changeset
|
54 getparport() |
| 71 | 55 |
| 56 self.standalone = standalone | |
| 57 self.machine_name = machine_name | |
| 58 | |
| 59 def sendupdates(self, levels): | |
| 60 if (not self.dummy) and levels: | |
| 61 print "update:", levels | |
| 62 | |
| 63 if self.standalone: | |
| 64 print "standalone sendlevels", levels | |
| 65 sendlevels(parselist(levels)) | |
| 66 return | |
| 67 | |
| 68 pid = os.getpid() | |
| 69 s = ('%d ' % pid) + ' '.join([str(l) for l in levels]) + '\n' | |
| 70 # print "sending", s | |
| 71 self.sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) | |
| 72 self.sock.connect((self.machine_name, | |
| 73 socket.getservbyname('ethdmx', 'tcp'))) | |
| 74 self.sock.send(s) | |
| 75 | |
| 76 # response = self.sock.recv(100) | |
| 77 # print "response", response | |
| 78 # if response != 'ACK\n': | |
| 79 # raise "Didn't get ACK from DMX server" | |
| 80 | |
| 81 if __name__ == '__main__': | |
| 82 import SocketServer | |
| 83 getparport() | |
| 84 | |
| 85 class DMXHandler(SocketServer.StreamRequestHandler): | |
| 86 def handle(self): | |
| 87 global lastlevels | |
| 88 changed = self.rfile.readline(1000) | |
| 89 # self.wfile.write("ACK\n") | |
| 90 pairs = changed.split() | |
| 91 pid = pairs[0] | |
| 92 changes = pairs[1:] | |
| 93 | |
| 94 # print 'pairs', pairs | |
| 95 sethostlist(pid, changes) | |
| 96 | |
| 97 self.preplevels() | |
| 98 def preplevels(self): | |
| 99 global lastlevels | |
| 100 hosts = lastlevels.keys() | |
| 101 maxlevels = [0] * 68 | |
| 102 for h in hosts: | |
| 103 maxlevels = [max(hostlev, maxlev) | |
| 104 for hostlev, maxlev in zip(maxlevels, gethostlist(h))] | |
| 105 print "dmxhandler sending levels:", maxlevels | |
| 106 sendlevels(maxlevels) | |
| 107 | |
| 108 print "Running DMX over Ethernet socket server. Everything is under " + \ | |
| 109 "control." | |
| 110 | |
| 111 server = SocketServer.TCPServer(('', | |
| 112 socket.getservbyname('ethdmx', 'tcp')), DMXHandler) | |
| 113 server.serve_forever() |