light9: bin/dmxserver annotate

annotate bin/dmxserver @ 1858:7772cc48e016

reformat all python Ignore-this: 1135b78893f8b3d31badddda7f45678f

author	drewp@bigasterisk.com
date	Tue, 21 May 2019 23:56:12 +0000
parents	a5a44077c54c
children	f066d6e874db

rev	line source
686 a301a0039c66 buildout and rdflib updates Drew Perttula <drewp@bigasterisk.com> parents: 623 diff changeset	1 #!bin/python
0 45b12307c695 Initial revision drewp parents: diff changeset	2 """
1530 a5a44077c54c docs and error msgs drewp@bigasterisk.com parents: 1220 diff changeset	3 Replaced by bin/collector
a5a44077c54c docs and error msgs drewp@bigasterisk.com parents: 1220 diff changeset	4
0 45b12307c695 Initial revision drewp parents: diff changeset	5
45b12307c695 Initial revision drewp parents: diff changeset	6 this is the only process to talk to the dmx hardware. other clients
45b12307c695 Initial revision drewp parents: diff changeset	7 can connect to this server and present dmx output, and this server
45b12307c695 Initial revision drewp parents: diff changeset	8 will max ('pile-on') all the client requests.
45b12307c695 Initial revision drewp parents: diff changeset	9
45b12307c695 Initial revision drewp parents: diff changeset	10 this server has a level display which is the final set of values that
45b12307c695 Initial revision drewp parents: diff changeset	11 goes to the hardware.
45b12307c695 Initial revision drewp parents: diff changeset	12
45b12307c695 Initial revision drewp parents: diff changeset	13 clients shall connect to the xmlrpc server and send:
45b12307c695 Initial revision drewp parents: diff changeset	14
45b12307c695 Initial revision drewp parents: diff changeset	15 their PID (or some other cookie)
45b12307c695 Initial revision drewp parents: diff changeset	16
45b12307c695 Initial revision drewp parents: diff changeset	17 a length-n list of 0..1 levels which will represent the channel
45b12307c695 Initial revision drewp parents: diff changeset	18 values for the n first dmx channels.
45b12307c695 Initial revision drewp parents: diff changeset	19
45b12307c695 Initial revision drewp parents: diff changeset	20 server is port 8030; xmlrpc method is called outputlevels(pid,levellist).
45b12307c695 Initial revision drewp parents: diff changeset	21
116 9ddea0c614ee much prettier stdout, including a clock (so you can tell the server's running) drewp parents: 112 diff changeset	22 todo:
9ddea0c614ee much prettier stdout, including a clock (so you can tell the server's running) drewp parents: 112 diff changeset	23 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	24 if parport fails, run in dummy mode (and make an option for that too)
0 45b12307c695 Initial revision drewp parents: diff changeset	25 """
45b12307c695 Initial revision drewp parents: diff changeset	26
45b12307c695 Initial revision drewp parents: diff changeset	27 from __future__ import division
45b12307c695 Initial revision drewp parents: diff changeset	28 from twisted.internet import reactor
45b12307c695 Initial revision drewp parents: diff changeset	29 from twisted.web import xmlrpc, server
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	30 import sys, time, os
194 70d45c584776 minor old changes drewp parents: 140 diff changeset	31 from optparse import OptionParser
209 1a84c5e83d3e dmxserver and subcomposer work in new layout drewp@bigasterisk.com parents: 199 diff changeset	32 import run_local
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	33 import txosc.dispatch, txosc. async
333 44189a37a876 change dmxserver to use enttec opendmx drewp@bigasterisk.com parents: 210 diff changeset	34 from light9.io import ParportDMX, UsbDMX
44189a37a876 change dmxserver to use enttec opendmx drewp@bigasterisk.com parents: 210 diff changeset	35
209 1a84c5e83d3e dmxserver and subcomposer work in new layout drewp@bigasterisk.com parents: 199 diff changeset	36 from light9.updatefreq import Updatefreq
210 f41004d5a507 factored out some networking, new show/ layout, curvecalc works drewp@bigasterisk.com parents: 209 diff changeset	37 from light9 import networking
0 45b12307c695 Initial revision drewp parents: diff changeset	38
1220 d5e99fee786d twisted uses zmq (not xmlrpc) to send levels to dmxserver Drew Perttula <drewp@bigasterisk.com> parents: 1009 diff changeset	39 from txzmq import ZmqEndpoint, ZmqFactory, ZmqPullConnection, ZmqRequestTimeoutError
d5e99fee786d twisted uses zmq (not xmlrpc) to send levels to dmxserver Drew Perttula <drewp@bigasterisk.com> parents: 1009 diff changeset	40 import json
d5e99fee786d twisted uses zmq (not xmlrpc) to send levels to dmxserver Drew Perttula <drewp@bigasterisk.com> parents: 1009 diff changeset	41
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	42
1220 d5e99fee786d twisted uses zmq (not xmlrpc) to send levels to dmxserver Drew Perttula <drewp@bigasterisk.com> parents: 1009 diff changeset	43 def startZmq(port, outputlevels):
d5e99fee786d twisted uses zmq (not xmlrpc) to send levels to dmxserver Drew Perttula <drewp@bigasterisk.com> parents: 1009 diff changeset	44 zf = ZmqFactory()
d5e99fee786d twisted uses zmq (not xmlrpc) to send levels to dmxserver Drew Perttula <drewp@bigasterisk.com> parents: 1009 diff changeset	45 e = ZmqEndpoint('bind', 'tcp://*:%s' % port)
d5e99fee786d twisted uses zmq (not xmlrpc) to send levels to dmxserver Drew Perttula <drewp@bigasterisk.com> parents: 1009 diff changeset	46 s = ZmqPullConnection(zf, e)
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	47
1220 d5e99fee786d twisted uses zmq (not xmlrpc) to send levels to dmxserver Drew Perttula <drewp@bigasterisk.com> parents: 1009 diff changeset	48 def onPull(message):
d5e99fee786d twisted uses zmq (not xmlrpc) to send levels to dmxserver Drew Perttula <drewp@bigasterisk.com> parents: 1009 diff changeset	49 msg = json.loads(message[0])
d5e99fee786d twisted uses zmq (not xmlrpc) to send levels to dmxserver Drew Perttula <drewp@bigasterisk.com> parents: 1009 diff changeset	50 outputlevels(msg['clientid'], msg['levellist'])
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	51
1220 d5e99fee786d twisted uses zmq (not xmlrpc) to send levels to dmxserver Drew Perttula <drewp@bigasterisk.com> parents: 1009 diff changeset	52 s.onPull = onPull
1009 ba47676dde49 dmxserver can receive OSC requests too drewp@bigasterisk.com parents: 978 diff changeset	53
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	54
1009 ba47676dde49 dmxserver can receive OSC requests too drewp@bigasterisk.com parents: 978 diff changeset	55 class ReceiverApplication(object):
ba47676dde49 dmxserver can receive OSC requests too drewp@bigasterisk.com parents: 978 diff changeset	56 """
ba47676dde49 dmxserver can receive OSC requests too drewp@bigasterisk.com parents: 978 diff changeset	57 receive UDP OSC messages. address is /dmx/1 for dmx channel 1,
ba47676dde49 dmxserver can receive OSC requests too drewp@bigasterisk.com parents: 978 diff changeset	58 arguments are 0-1 floats for that channel and any number of
ba47676dde49 dmxserver can receive OSC requests too drewp@bigasterisk.com parents: 978 diff changeset	59 following channels.
ba47676dde49 dmxserver can receive OSC requests too drewp@bigasterisk.com parents: 978 diff changeset	60 """
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	61
1009 ba47676dde49 dmxserver can receive OSC requests too drewp@bigasterisk.com parents: 978 diff changeset	62 def __init__(self, port, lightServer):
ba47676dde49 dmxserver can receive OSC requests too drewp@bigasterisk.com parents: 978 diff changeset	63 self.port = port
ba47676dde49 dmxserver can receive OSC requests too drewp@bigasterisk.com parents: 978 diff changeset	64 self.lightServer = lightServer
ba47676dde49 dmxserver can receive OSC requests too drewp@bigasterisk.com parents: 978 diff changeset	65 self.receiver = txosc.dispatch.Receiver()
ba47676dde49 dmxserver can receive OSC requests too drewp@bigasterisk.com parents: 978 diff changeset	66 self.receiver.addCallback("/dmx/*", self.pixel_handler)
ba47676dde49 dmxserver can receive OSC requests too drewp@bigasterisk.com parents: 978 diff changeset	67 self._server_port = reactor.listenUDP(
ba47676dde49 dmxserver can receive OSC requests too drewp@bigasterisk.com parents: 978 diff changeset	68 self.port,
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	69 txosc. async .DatagramServerProtocol(self.receiver),
1009 ba47676dde49 dmxserver can receive OSC requests too drewp@bigasterisk.com parents: 978 diff changeset	70 interface='0.0.0.0')
ba47676dde49 dmxserver can receive OSC requests too drewp@bigasterisk.com parents: 978 diff changeset	71 print "Listening OSC on udp port %s" % (self.port)
ba47676dde49 dmxserver can receive OSC requests too drewp@bigasterisk.com parents: 978 diff changeset	72
ba47676dde49 dmxserver can receive OSC requests too drewp@bigasterisk.com parents: 978 diff changeset	73 def pixel_handler(self, message, address):
ba47676dde49 dmxserver can receive OSC requests too drewp@bigasterisk.com parents: 978 diff changeset	74 # this is already 1-based though I don't know why
ba47676dde49 dmxserver can receive OSC requests too drewp@bigasterisk.com parents: 978 diff changeset	75 startChannel = int(message.address.split('/')[2])
ba47676dde49 dmxserver can receive OSC requests too drewp@bigasterisk.com parents: 978 diff changeset	76 levels = [a.value for a in message.arguments]
ba47676dde49 dmxserver can receive OSC requests too drewp@bigasterisk.com parents: 978 diff changeset	77 allLevels = [0] * (startChannel - 1) + levels
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	78 self.lightServer.xmlrpc_outputlevels("osc@%s" % startChannel, allLevels)
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	79
1009 ba47676dde49 dmxserver can receive OSC requests too drewp@bigasterisk.com parents: 978 diff changeset	80
0 45b12307c695 Initial revision drewp parents: diff changeset	81 class XMLRPCServe(xmlrpc.XMLRPC):
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	82
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	83 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	84
9ddea0c614ee much prettier stdout, including a clock (so you can tell the server's running) drewp parents: 112 diff changeset	85 xmlrpc.XMLRPC.__init__(self)
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	86
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	87 self.clientlevels = {} # clientID : list of levels
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	88 self.lastseen = {} # clientID : time last seen
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	89 self.clientfreq = {} # clientID : updatefreq
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	90
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	91 self.combinedlevels = [] # list of levels, after max'ing the clients
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	92 self.clientschanged = 1 # have clients sent anything since the last send?
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	93 self.options = options
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	94 self.lastupdate = 0 # time of last dmx send
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	95 self.laststatsprint = 0 # time
134 f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	96
f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	97 # desired seconds between sendlevels() calls
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	98 self.calldelay = 1 / options.updates_per_sec
0 45b12307c695 Initial revision drewp parents: diff changeset	99
45b12307c695 Initial revision drewp parents: diff changeset	100 print "starting parport connection"
978 ce159eea90b5 now 90 dimmers drewp@bigasterisk.com parents: 975 diff changeset	101 self.parportdmx = UsbDMX(dimmers=90, port=options.dmx_device)
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	102 if os.environ.get('DMXDUMMY', 0):
199 cde2ae379be0 added dummy mode, activated by env var DMXDUMMY=1 drewp parents: 194 diff changeset	103 self.parportdmx.godummy()
cde2ae379be0 added dummy mode, activated by env var DMXDUMMY=1 drewp parents: 194 diff changeset	104 else:
cde2ae379be0 added dummy mode, activated by env var DMXDUMMY=1 drewp parents: 194 diff changeset	105 self.parportdmx.golive()
0 45b12307c695 Initial revision drewp parents: diff changeset	106
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	107 self.updatefreq = Updatefreq() # freq of actual dmx sends
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	108 self.num_unshown_updates = None
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	109 self.lastshownlevels = None
134 f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	110 # start the loop
0 45b12307c695 Initial revision drewp parents: diff changeset	111 self.sendlevels()
134 f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	112
f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	113 # the other loop
f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	114 self.purgeclients()
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	115
118 2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	116 def purgeclients(self):
194 70d45c584776 minor old changes drewp parents: 140 diff changeset	117 """forget about any clients who haven't sent levels in a while.
70d45c584776 minor old changes drewp parents: 140 diff changeset	118 this runs in a loop"""
134 f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	119
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	120 purge_age = 10 # seconds
134 f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	121
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	122 reactor.callLater(1, self.purgeclients)
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	123
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	124 now = time.time()
353 941cfe1e1691 lightsim now reads levels from dmxserver drewp@bigasterisk.com parents: 352 diff changeset	125 cids = self.lastseen.keys()
194 70d45c584776 minor old changes drewp parents: 140 diff changeset	126 for cid in cids:
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	127 lastseen = self.lastseen[cid]
353 941cfe1e1691 lightsim now reads levels from dmxserver drewp@bigasterisk.com parents: 352 diff changeset	128 if lastseen < now - purge_age:
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	129 print("forgetting client %s (no activity for %s sec)" %
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	130 (cid, purge_age))
353 941cfe1e1691 lightsim now reads levels from dmxserver drewp@bigasterisk.com parents: 352 diff changeset	131 try:
941cfe1e1691 lightsim now reads levels from dmxserver drewp@bigasterisk.com parents: 352 diff changeset	132 del self.clientlevels[cid]
941cfe1e1691 lightsim now reads levels from dmxserver drewp@bigasterisk.com parents: 352 diff changeset	133 except KeyError:
941cfe1e1691 lightsim now reads levels from dmxserver drewp@bigasterisk.com parents: 352 diff changeset	134 pass
194 70d45c584776 minor old changes drewp parents: 140 diff changeset	135 del self.clientfreq[cid]
118 2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	136 del self.lastseen[cid]
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	137
0 45b12307c695 Initial revision drewp parents: diff changeset	138 def sendlevels(self):
134 f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	139 """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	140 in a while"""
f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	141
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	142 reactor.callLater(self.calldelay, self.sendlevels)
134 f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	143
0 45b12307c695 Initial revision drewp parents: diff changeset	144 if self.clientschanged:
45b12307c695 Initial revision drewp parents: diff changeset	145 # recalc levels
45b12307c695 Initial revision drewp parents: diff changeset	146
118 2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	147 self.calclevels()
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	148
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	149 if (self.num_unshown_updates is None or # first time
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	150 self.options.fast_updates or # show always
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	151 (
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	152 self.combinedlevels != self.lastshownlevels and # changed
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	153 self.num_unshown_updates > 5)): # not too frequent
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	154 self.num_unshown_updates = 0
118 2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	155 self.printlevels()
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	156 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	157 else:
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	158 self.num_unshown_updates += 1
116 9ddea0c614ee much prettier stdout, including a clock (so you can tell the server's running) drewp parents: 112 diff changeset	159
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	160 if time.time() > self.laststatsprint + 2:
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	161 self.laststatsprint = time.time()
118 2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	162 self.printstats()
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	163
333 44189a37a876 change dmxserver to use enttec opendmx drewp@bigasterisk.com parents: 210 diff changeset	164 # used to be a fixed 1 in here, for the max delay between
44189a37a876 change dmxserver to use enttec opendmx drewp@bigasterisk.com parents: 210 diff changeset	165 # calls, instead of calldelay
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	166 if self.clientschanged or time.time(
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	167 ) > self.lastupdate + self.calldelay:
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	168 self.lastupdate = time.time()
134 f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	169 self.sendlevels_dmx()
f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	170
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	171 self.clientschanged = 0 # clear the flag
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	172
118 2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	173 def calclevels(self):
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	174 """combine all the known client levels into self.combinedlevels"""
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	175 self.combinedlevels = []
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	176 for chan in range(0, self.parportdmx.dimmers):
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	177 x = 0
118 2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	178 for clientlist in self.clientlevels.values():
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	179 if len(clientlist) > chan:
118 2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	180 # clamp client levels to 0..1
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	181 cl = max(0, min(1, clientlist[chan]))
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	182 x = max(x, cl)
118 2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	183 self.combinedlevels.append(x)
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	184
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	185 def printlevels(self):
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	186 """write all the levels to stdout"""
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	187 print "Levels:", "".join(
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	188 ["% 2d " % (x * 100) for x in self.combinedlevels])
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	189
118 2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	190 def printstats(self):
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	191 """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	192
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	193 sys.stdout.write("dmxserver up at %s, [polls %s] " % (
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	194 time.strftime("%H:%M:%S"),
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	195 str(self.updatefreq),
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	196 ))
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	197 for cid, freq in self.clientfreq.items():
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	198 sys.stdout.write("[%s %s] " % (cid, str(freq)))
118 2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	199 sys.stdout.write("\r")
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	200 sys.stdout.flush()
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	201
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	202 def sendlevels_dmx(self):
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	203 """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	204 # 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	205 if self.parportdmx:
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	206 self.parportdmx.sendlevels([l * 100 for l in self.combinedlevels])
118 2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	207 self.updatefreq.update()
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	208
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	209 def xmlrpc_echo(self, x):
0 45b12307c695 Initial revision drewp parents: diff changeset	210 return x
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	211
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	212 def xmlrpc_outputlevels(self, cid, levellist):
118 2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	213 """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	214 the variable-length dmx levellist (scaled 0..1)"""
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	215 if levellist != self.clientlevels.get(cid, None):
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	216 self.clientlevels[cid] = levellist
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	217 self.clientschanged = 1
353 941cfe1e1691 lightsim now reads levels from dmxserver drewp@bigasterisk.com parents: 352 diff changeset	218 self.trackClientFreq(cid)
941cfe1e1691 lightsim now reads levels from dmxserver drewp@bigasterisk.com parents: 352 diff changeset	219 return "ok"
941cfe1e1691 lightsim now reads levels from dmxserver drewp@bigasterisk.com parents: 352 diff changeset	220
941cfe1e1691 lightsim now reads levels from dmxserver drewp@bigasterisk.com parents: 352 diff changeset	221 def xmlrpc_currentlevels(self, cid):
941cfe1e1691 lightsim now reads levels from dmxserver drewp@bigasterisk.com parents: 352 diff changeset	222 """get a list of levels we're currently sending out. All
941cfe1e1691 lightsim now reads levels from dmxserver drewp@bigasterisk.com parents: 352 diff changeset	223 channels beyond the list you get back, they're at zero."""
941cfe1e1691 lightsim now reads levels from dmxserver drewp@bigasterisk.com parents: 352 diff changeset	224 # if this is still too slow, it might help to return a single
941cfe1e1691 lightsim now reads levels from dmxserver drewp@bigasterisk.com parents: 352 diff changeset	225 # pickled string
941cfe1e1691 lightsim now reads levels from dmxserver drewp@bigasterisk.com parents: 352 diff changeset	226 self.trackClientFreq(cid)
941cfe1e1691 lightsim now reads levels from dmxserver drewp@bigasterisk.com parents: 352 diff changeset	227 trunc = self.combinedlevels[:]
941cfe1e1691 lightsim now reads levels from dmxserver drewp@bigasterisk.com parents: 352 diff changeset	228 i = len(trunc) - 1
941cfe1e1691 lightsim now reads levels from dmxserver drewp@bigasterisk.com parents: 352 diff changeset	229 if i < 0:
941cfe1e1691 lightsim now reads levels from dmxserver drewp@bigasterisk.com parents: 352 diff changeset	230 return []
941cfe1e1691 lightsim now reads levels from dmxserver drewp@bigasterisk.com parents: 352 diff changeset	231 while trunc[i] == 0 and i >= 0:
941cfe1e1691 lightsim now reads levels from dmxserver drewp@bigasterisk.com parents: 352 diff changeset	232 i -= 1
941cfe1e1691 lightsim now reads levels from dmxserver drewp@bigasterisk.com parents: 352 diff changeset	233 if i < 0:
941cfe1e1691 lightsim now reads levels from dmxserver drewp@bigasterisk.com parents: 352 diff changeset	234 return []
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	235 trunc = trunc[:i + 1]
353 941cfe1e1691 lightsim now reads levels from dmxserver drewp@bigasterisk.com parents: 352 diff changeset	236 return trunc
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	237
353 941cfe1e1691 lightsim now reads levels from dmxserver drewp@bigasterisk.com parents: 352 diff changeset	238 def trackClientFreq(self, cid):
941cfe1e1691 lightsim now reads levels from dmxserver drewp@bigasterisk.com parents: 352 diff changeset	239 if cid not in self.lastseen:
941cfe1e1691 lightsim now reads levels from dmxserver drewp@bigasterisk.com parents: 352 diff changeset	240 print "hello new client %s" % cid
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	241 self.clientfreq[cid] = Updatefreq()
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	242 self.lastseen[cid] = time.time()
118 2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	243 self.clientfreq[cid].update()
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	244
352 9d1f323fb3d3 new bin/lightsim tied to dmxserver Drew Perttula <drewp@bigasterisk.com> parents: 333 diff changeset	245
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	246 parser = OptionParser()
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	247 parser.add_option("-f",
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	248 "--fast-updates",
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	249 action='store_true',
118 2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	250 help=('display all dmx output to stdout instead '
2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	251 'of the usual reduced output'))
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	252 parser.add_option("-r",
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	253 "--updates-per-sec",
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	254 type='float',
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	255 default=20,
134 f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	256 help=('dmx output frequency'))
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	257 parser.add_option("-d",
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	258 "--dmx-device",
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	259 default='/dev/dmx0',
876 e263c4bd73f9 pass dmx choice into dmxserver Drew Perttula <drewp@bigasterisk.com> parents: 686 diff changeset	260 help='dmx device name')
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	261 parser.add_option("-n",
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	262 "--dummy",
7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	263 action="store_true",
419 632539a8c30e dmxserver now takes -n/--dummy drewp@bigasterisk.com parents: 353 diff changeset	264 help="dummy mode, same as DMXDUMMY=1 env variable")
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	265 (options, songfiles) = parser.parse_args()
118 2c25a69c084d now tracks update frequencies of the server and each client drewp parents: 116 diff changeset	266
134 f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	267 print options
f2f73a2171e6 many adjustments to the loops and timing drewp parents: 118 diff changeset	268
419 632539a8c30e dmxserver now takes -n/--dummy drewp@bigasterisk.com parents: 353 diff changeset	269 if options.dummy:
632539a8c30e dmxserver now takes -n/--dummy drewp@bigasterisk.com parents: 353 diff changeset	270 os.environ['DMXDUMMY'] = "1"
632539a8c30e dmxserver now takes -n/--dummy drewp@bigasterisk.com parents: 353 diff changeset	271
623 46d319974176 move networking settings to config.n3 drewp@bigasterisk.com parents: 419 diff changeset	272 port = networking.dmxServer.port
210 f41004d5a507 factored out some networking, new show/ layout, curvecalc works drewp@bigasterisk.com parents: 209 diff changeset	273 print "starting xmlrpc server on port %s" % port
1009 ba47676dde49 dmxserver can receive OSC requests too drewp@bigasterisk.com parents: 978 diff changeset	274 xmlrpcServe = XMLRPCServe(options)
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	275 reactor.listenTCP(port, server.Site(xmlrpcServe))
1009 ba47676dde49 dmxserver can receive OSC requests too drewp@bigasterisk.com parents: 978 diff changeset	276
1220 d5e99fee786d twisted uses zmq (not xmlrpc) to send levels to dmxserver Drew Perttula <drewp@bigasterisk.com> parents: 1009 diff changeset	277 startZmq(networking.dmxServerZmq.port, xmlrpcServe.xmlrpc_outputlevels)
1858 7772cc48e016 reformat all python drewp@bigasterisk.com parents: 1530 diff changeset	278
1009 ba47676dde49 dmxserver can receive OSC requests too drewp@bigasterisk.com parents: 978 diff changeset	279 oscApp = ReceiverApplication(9051, xmlrpcServe)
ba47676dde49 dmxserver can receive OSC requests too drewp@bigasterisk.com parents: 978 diff changeset	280
0 45b12307c695 Initial revision drewp parents: diff changeset	281 reactor.run()

Mercurial > code > home > repos > light9

annotate bin/dmxserver @ 1858:7772cc48e016