AEM
|
Public Member Functions | |
def | __init__ (self, inq, outq, mailer, stopEvt) |
def | do_work (self, thing) |
def | run (self) |
Data Fields | |
inQ | |
init | |
comms | |
bid | |
stopEvent | |
This helper thread unburdens the server from the processing of the incoming data. It is needed to prevent a bottleneck at the receiving end of the serial port.
def commsMgr.ReadInputThread.__init__ | ( | self, | |
inq, | |||
outq, | |||
mailer, | |||
stopEvt | |||
) |
def commsMgr.ReadInputThread.do_work | ( | self, | |
thing | |||
) |
take a thing of the incoming queue, process it. the thing is n blocks of 9 bytes, so we break it down into 9s and then process each nine using pack/unpack. The 1st pack contains the BID and is processed differently.
def commsMgr.ReadInputThread.run | ( | self | ) |
Thread run method. pops the queue, sends the popped thing to be consumed. if a None value is popped, the method exits properply and the thread ends.
commsMgr.ReadInputThread.bid |
commsMgr.ReadInputThread.comms |
commsMgr.ReadInputThread.init |
commsMgr.ReadInputThread.inQ |
commsMgr.ReadInputThread.stopEvent |