blob: 710ca43effebceb13ef788c8215fcb77efb039ae (
plain)
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
|
from operationscore.Renderer import *
import util.PacketComposition as composer
import util.NetworkOps as network
import util.TimeOps as timeops
import socket,pdb
sock_port = 6038
class IndoorRenderer(Renderer):
"""IndoorRenderer is a renderer for a specific Light System"""
def initRenderer(self):
self.stripLocations = {} #Dict that stores info necessary to render to
#strips
self.sockets = {} #dict of (IP)->Socket
#a strip
powerSupplies = self.argDict['PowerSupply']
if not type(powerSupplies) == type([]):
powerSupplies = [powerSupplies]
for powerSupply in powerSupplies:
ip = powerSupply['IP']
stripsInPowerSupply = powerSupply['PortMapping']
for stripId in stripsInPowerSupply:
self.stripLocations[stripId] = (ip, \
stripsInPowerSupply[stripId])
self.broadSocket = network.getBroadcastSocket(6038)
def render(self, lightSystem, currentTime=timeops.time()):
#try:
for pixelStrip in lightSystem.pixelStrips:
stripId = pixelStrip.argDict['Id']
(ip, port) = self.stripLocations[stripId]
if not ip in self.sockets: #do we have a socket to this
#strip? if not, spin off a new one
self.sockets[ip] = network.getConnectedSocket(ip,sock_port)
packet = composer.composePixelStripPacket(pixelStrip, port, currentTime)
self.sockets[ip].send(packet, 0x00)
synchPacket = composer.composeSynchPacket()
#pdb.set_trace()
#self.broadSocket.sendto(synchPacket, ('10.0.32.255', 6038))
|
