light9: bin/dmxserver annotate

annotate bin/dmxserver @ 210:f41004d5a507

factored out some networking, new show/ layout, curvecalc works

author	drewp@bigasterisk.com
date	Sun, 10 Apr 2005 20:54:14 +0000
parents	1a84c5e83d3e
children	44189a37a876

rev	line source
116 9ddea0c614ee much prettier stdout, including a clock (so you can tell the server's running) drewp parents: 112 diff changeset	1 #!/usr/bin/python
0 45b12307c695 Initial revision drewp parents: diff changeset	2 """
45b12307c695 Initial revision drewp parents: diff changeset	3
45b12307c695 Initial revision drewp parents: diff changeset	4 this is the only process to talk to the dmx hardware. other clients
45b12307c695 Initial revision drewp parents: diff changeset	5 can connect to this server and present dmx output, and this server
45b12307c695 Initial revision drewp parents: diff changeset	6 will max ('pile-on') all the client requests.
45b12307c695 Initial revision drewp parents: diff changeset	7
45b12307c695 Initial revision drewp parents: diff changeset	8 this server has a level display which is the final set of values that
45b12307c695 Initial revision drewp parents: diff changeset	9 goes to the hardware.
45b12307c695 Initial revision drewp parents: diff changeset	10
45b12307c695 Initial revision drewp parents: diff changeset	11 clients shall connect to the xmlrpc server and send:
45b12307c695 Initial revision drewp parents: diff changeset	12
45b12307c695 Initial revision drewp parents: diff changeset	13 their PID (or some other cookie)
45b12307c695 Initial revision drewp parents: diff changeset	14
45b12307c695 Initial revision drewp parents: diff changeset	15 a length-n list of 0..1 levels which will represent the channel
45b12307c695 Initial revision drewp parents: diff changeset	16 values for the n first dmx channels.
45b12307c695 Initial revision drewp parents: diff changeset	17
45b12307c695 Initial revision drewp parents: diff changeset	18 server is port 8030; xmlrpc method is called outputlevels(pid,levellist).
45b12307c695 Initial revision drewp parents: diff changeset	19
116 9ddea0c614ee much prettier stdout, including a clock (so you can tell the server's running) drewp parents: 112 diff changeset	20 todo:
9ddea0c614ee much prettier stdout, including a clock (so you can tell the server's running) drewp parents: 112 diff changeset	21 save dmx on quit and restore on restart
9ddea0c614ee much prettier stdout, including a clock (so you can tell the server's running) drewp parents: 112 diff changeset	22 if parport fails, run in dummy mode (and make an option for that too)
0 45b12307c695 Initial revision drewp parents: diff changeset	23 """
45b12307c695 Initial revision drewp parents: diff changeset	24
45b12307c695 Initial revision drewp parents: diff changeset	25 from __future__ import division
45b12307c695 Initial revision drewp parents: diff changeset	26 from twisted.internet import reactor
45b12307c695 Initial revision drewp parents: diff changeset	27 from twisted.web import xmlrpc, server
199 cde2ae379be0 added dummy mode, activated by env var DMXDUMMY=1 drewp parents: 194 diff changeset	28 import sys,time,os
194 70d45c584776 minor old changes drewp parents: 140 diff changeset	29 from optparse import OptionParser
209 1a84c5e83d3e dmxserver and subcomposer work in new layout drewp@bigasterisk.com parents: 199 diff changeset	30 import run_local
1a84c5e83d3e dmxserver and subcomposer work in new layout drewp@bigasterisk.com parents: 199 diff changeset	31 from light9.io import ParportDMX
1a84c5e83d3e dmxserver and subcomposer work in new layout drewp@bigasterisk.com parents: 199 diff changeset	32 from light9.updatefreq import Updatefreq
210 f41004d5a507 factored out some networking, new show/ layout, curvecalc works drewp@bigasterisk.com parents: 209 diff changeset	33 from light9 import networking
0 45b12307c695 Initial revision drewp parents: diff changeset	34
45b12307c695 Initial revision drewp parents: diff changeset	35 class XMLRPCServe(xmlrpc.XMLRPC):
118 2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	36 def __init__(self,options):
116 9ddea0c614ee much prettier stdout, including a clock (so you can tell the server's running) drewp parents: 112 diff changeset	37
9ddea0c614ee much prettier stdout, including a clock (so you can tell the server's running) drewp parents: 112 diff changeset	38 xmlrpc.XMLRPC.__init__(self)
9ddea0c614ee much prettier stdout, including a clock (so you can tell the server's running) drewp parents: 112 diff changeset	39
118 2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	40 self.clientlevels={} # clientID : list of levels
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	41 self.lastseen={} # clientID : time last seen
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	42 self.clientfreq={} # clientID : updatefreq
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	43
0 45b12307c695 Initial revision drewp parents: diff changeset	44 self.combinedlevels=[] # list of levels, after max'ing the clients
45b12307c695 Initial revision drewp parents: diff changeset	45 self.clientschanged=1 # have clients sent anything since the last send?
118 2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	46 self.options=options
134 f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	47 self.lastupdate=0 # time of last dmx send
f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	48 self.laststatsprint=0 # time
f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	49
f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	50 # desired seconds between sendlevels() calls
f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	51 self.calldelay=1/options.updates_per_sec
0 45b12307c695 Initial revision drewp parents: diff changeset	52
45b12307c695 Initial revision drewp parents: diff changeset	53 print "starting parport connection"
45b12307c695 Initial revision drewp parents: diff changeset	54 self.parportdmx=ParportDMX()
199 cde2ae379be0 added dummy mode, activated by env var DMXDUMMY=1 drewp parents: 194 diff changeset	55 if os.environ.get('DMXDUMMY',0):
cde2ae379be0 added dummy mode, activated by env var DMXDUMMY=1 drewp parents: 194 diff changeset	56 self.parportdmx.godummy()
cde2ae379be0 added dummy mode, activated by env var DMXDUMMY=1 drewp parents: 194 diff changeset	57 else:
cde2ae379be0 added dummy mode, activated by env var DMXDUMMY=1 drewp parents: 194 diff changeset	58 self.parportdmx.golive()
cde2ae379be0 added dummy mode, activated by env var DMXDUMMY=1 drewp parents: 194 diff changeset	59
0 45b12307c695 Initial revision drewp parents: diff changeset	60
134 f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	61 self.updatefreq=Updatefreq() # freq of actual dmx sends
116 9ddea0c614ee much prettier stdout, including a clock (so you can tell the server's running) drewp parents: 112 diff changeset	62 self.num_unshown_updates=None
118 2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	63 self.lastshownlevels=None
134 f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	64 # start the loop
0 45b12307c695 Initial revision drewp parents: diff changeset	65 self.sendlevels()
134 f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	66
f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	67 # the other loop
f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	68 self.purgeclients()
118 2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	69
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	70 def purgeclients(self):
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	71
194 70d45c584776 minor old changes drewp parents: 140 diff changeset	72 """forget about any clients who haven't sent levels in a while.
70d45c584776 minor old changes drewp parents: 140 diff changeset	73 this runs in a loop"""
134 f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	74
f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	75 purge_age=10 # seconds
f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	76
f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	77 reactor.callLater(1,self.purgeclients)
f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	78
118 2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	79 now=time.time()
194 70d45c584776 minor old changes drewp parents: 140 diff changeset	80 cids=self.clientlevels.keys()
70d45c584776 minor old changes drewp parents: 140 diff changeset	81 for cid in cids:
70d45c584776 minor old changes drewp parents: 140 diff changeset	82 lastseen=self.lastseen[cid]
134 f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	83 if lastseen<now-purge_age:
f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	84 print ("forgetting client %s (no activity for %s sec)" %
f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	85 (cid,purge_age))
118 2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	86 del self.clientlevels[cid]
194 70d45c584776 minor old changes drewp parents: 140 diff changeset	87 del self.clientfreq[cid]
118 2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	88 del self.lastseen[cid]
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	89
0 45b12307c695 Initial revision drewp parents: diff changeset	90 def sendlevels(self):
134 f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	91
f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	92 """sends to dmx if levels have changed, or if we havent sent
f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	93 in a while"""
f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	94
f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	95 reactor.callLater(self.calldelay,self.sendlevels)
f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	96
0 45b12307c695 Initial revision drewp parents: diff changeset	97 if self.clientschanged:
45b12307c695 Initial revision drewp parents: diff changeset	98 # recalc levels
45b12307c695 Initial revision drewp parents: diff changeset	99
118 2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	100 self.calclevels()
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	101
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	102 if (self.num_unshown_updates is None or # first time
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	103 self.options.fast_updates or # show always
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	104 (self.combinedlevels!=self.lastshownlevels and # changed
140 8e6165bc1ca5 try to show levels more often (it's still not often enough) drewp parents: 134 diff changeset	105 self.num_unshown_updates>5)): # not too frequent
116 9ddea0c614ee much prettier stdout, including a clock (so you can tell the server's running) drewp parents: 112 diff changeset	106 self.num_unshown_updates=0
118 2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	107 self.printlevels()
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	108 self.lastshownlevels=self.combinedlevels[:]
116 9ddea0c614ee much prettier stdout, including a clock (so you can tell the server's running) drewp parents: 112 diff changeset	109 else:
9ddea0c614ee much prettier stdout, including a clock (so you can tell the server's running) drewp parents: 112 diff changeset	110 self.num_unshown_updates+=1
9ddea0c614ee much prettier stdout, including a clock (so you can tell the server's running) drewp parents: 112 diff changeset	111
134 f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	112 if time.time()>self.laststatsprint+2:
f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	113 self.laststatsprint=time.time()
118 2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	114 self.printstats()
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	115
134 f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	116 if self.clientschanged or time.time()>self.lastupdate+1:
f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	117 self.lastupdate=time.time()
f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	118 self.sendlevels_dmx()
f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	119
f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	120 self.clientschanged=0 # clear the flag
f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	121
118 2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	122 def calclevels(self):
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	123 """combine all the known client levels into self.combinedlevels"""
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	124 self.combinedlevels=[]
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	125 for chan in range(0,self.parportdmx.dimmers):
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	126 x=0
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	127 for clientlist in self.clientlevels.values():
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	128 if len(clientlist)>chan:
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	129 # clamp client levels to 0..1
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	130 cl=max(0,min(1,clientlist[chan]))
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	131 x=max(x,cl)
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	132 self.combinedlevels.append(x)
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	133
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	134 def printlevels(self):
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	135 """write all the levels to stdout"""
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	136 print "Levels:","".join(["% 2d "%(x*100) for
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	137 x in self.combinedlevels])
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	138
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	139 def printstats(self):
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	140 """print the clock, freq, etc, with a \r at the end"""
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	141
134 f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	142 sys.stdout.write("dmxserver up at %s, [polls %s] "%
118 2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	143 (time.strftime("%H:%M:%S"),
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	144 str(self.updatefreq),
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	145 ))
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	146 for cid,freq in self.clientfreq.items():
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	147 sys.stdout.write("[%s %s] " % (cid,str(freq)))
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	148 sys.stdout.write("\r")
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	149 sys.stdout.flush()
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	150
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	151 def sendlevels_dmx(self):
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	152 """output self.combinedlevels to dmx, and keep the updates/sec stats"""
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	153 # they'll get divided by 100
116 9ddea0c614ee much prettier stdout, including a clock (so you can tell the server's running) drewp parents: 112 diff changeset	154 if self.parportdmx:
118 2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	155 self.parportdmx.sendlevels([l*100 for l in self.combinedlevels])
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	156 self.updatefreq.update()
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	157
0 45b12307c695 Initial revision drewp parents: diff changeset	158 def xmlrpc_echo(self,x):
45b12307c695 Initial revision drewp parents: diff changeset	159 return x
45b12307c695 Initial revision drewp parents: diff changeset	160
118 2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	161 def xmlrpc_outputlevels(self,cid,levellist):
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	162 """send a unique id for your client (name+pid maybe), then
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	163 the variable-length dmx levellist (scaled 0..1)"""
194 70d45c584776 minor old changes drewp parents: 140 diff changeset	164 if levellist!=self.clientlevels.get(cid,None):
134 f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	165 self.clientlevels[cid]=levellist
f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	166 self.clientschanged=1
f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	167 if cid not in self.lastseen:
f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	168 print "hello new client %s" % cid
f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	169 self.clientfreq[cid]=Updatefreq()
f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	170
118 2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	171 self.lastseen[cid]=time.time()
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	172 self.clientfreq[cid].update()
0 45b12307c695 Initial revision drewp parents: diff changeset	173 return "ok"
45b12307c695 Initial revision drewp parents: diff changeset	174
118 2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	175 parser=OptionParser()
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	176 parser.add_option("-f","--fast-updates",action='store_true',
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	177 help=('display all dmx output to stdout instead '
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	178 'of the usual reduced output'))
134 f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	179 parser.add_option("-r","--updates-per-sec",type='float',default=20,
f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	180 help=('dmx output frequency'))
118 2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	181 (options,songfiles)=parser.parse_args()
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	182
134 f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	183 print options
f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	184
210 f41004d5a507 factored out some networking, new show/ layout, curvecalc works drewp@bigasterisk.com parents: 209 diff changeset	185 port = networking.dmxServerPort()
f41004d5a507 factored out some networking, new show/ layout, curvecalc works drewp@bigasterisk.com parents: 209 diff changeset	186 print "starting xmlrpc server on port %s" % port
f41004d5a507 factored out some networking, new show/ layout, curvecalc works drewp@bigasterisk.com parents: 209 diff changeset	187 reactor.listenTCP(port,server.Site(XMLRPCServe(options)))
0 45b12307c695 Initial revision drewp parents: diff changeset	188 reactor.run()
45b12307c695 Initial revision drewp parents: diff changeset	189

Mercurial > code > home > repos > light9

annotate bin/dmxserver @ 210:f41004d5a507