fix cmdServer
This commit is contained in:
@ -156,9 +156,10 @@ class MyCmdUserData(object):
|
|||||||
self.registers = registers
|
self.registers = registers
|
||||||
|
|
||||||
class CmdServer(threading.Thread):
|
class CmdServer(threading.Thread):
|
||||||
def __init__(self, address, port, notifier, registers):
|
def __init__(self, config, notifier, registers):
|
||||||
super().__init__()
|
super().__init__()
|
||||||
self.server = MyThreadingTCPServer((address, port), CmdHandle, MyCmdUserData(notifier, registers))
|
self.config = config
|
||||||
|
self.server = MyThreadingTCPServer((config.cmdAddress, config.cmdPort), CmdHandle, MyCmdUserData(notifier, registers))
|
||||||
|
|
||||||
def start(self):
|
def start(self):
|
||||||
self.server.serve_forever()
|
self.server.serve_forever()
|
||||||
|
@ -5,4 +5,6 @@ class Config(object):
|
|||||||
self.mqttBrokerPort = 1883
|
self.mqttBrokerPort = 1883
|
||||||
self.mqttLogin = ''
|
self.mqttLogin = ''
|
||||||
self.mqttPassword = ''
|
self.mqttPassword = ''
|
||||||
|
self.cmdAddress = '127.0.0.1'
|
||||||
|
self.cmdPort = 9999
|
||||||
|
|
||||||
|
@ -35,5 +35,5 @@ if __name__ == "__main__":
|
|||||||
nf.register(qf)
|
nf.register(qf)
|
||||||
qf.start()
|
qf.start()
|
||||||
|
|
||||||
cs = CmdServer.CmdServer(config, '127.0.0.1',9999, nf, datapoints)
|
cs = CmdServer.CmdServer(config, nf, datapoints)
|
||||||
cs.start()
|
cs.start()
|
Reference in New Issue
Block a user