jyapayne/nxbt
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Fixed controller state sharing

Browse source
This commit is contained in:
Brikwerk 2020-05-27 01:28:53 -07:00
commit 78e62fd013
2 changed files with 8 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

2
demo.py
View file

@ -12,4 +12,4 @@ if __name__ == "__main__":
while True: while True:
time.sleep(1) time.sleep(1)
print(nxbt.get_state()) print(nxbt.get_state()[0])

13
nxbt/nxbt.py
View file

@ -60,7 +60,6 @@ class Nxbt():
cm = ControllerManager(state) cm = ControllerManager(state)
while True: while True:
try: try:
msg = task_queue.get_nowait() msg = task_queue.get_nowait()
except queue.Empty: except queue.Empty:
@ -122,17 +121,19 @@ class ControllerManager():
def __init__(self, state): def __init__(self, state):
self.state = state self.state = state
self.controller_resources = Manager()
self.controller_states = [] self.controller_states = []
self.controller_queues = [] self.controller_queues = []
def create_controller(self, index, controller_type, adapter_path): def create_controller(self, index, controller_type, adapter_path):
controller_queue = Queue() controller_queue = Queue()
controller_state = {
"state": "initializing", controller_state = self.controller_resources.dict()
"finished_macros": [], controller_state["state"] = "initializing"
"errors": False controller_state["finished_macros"] = []
} controller_state["errors"] = False
self.state[index] = controller_state self.state[index] = controller_state
# Get the last parameter of the path, AKA the ID # Get the last parameter of the path, AKA the ID
device_id = adapter_path.split("/")[-1] device_id = adapter_path.split("/")[-1]