From 3d394b22f81c257f0604371b1fdb2901040bde12 Mon Sep 17 00:00:00 2001 From: Emanuele Date: Fri, 20 Mar 2020 11:08:53 +0100 Subject: [PATCH] mappa id code globale --- driver/tsc_manager.py | 26 +++++++++++++++----------- 1 file changed, 15 insertions(+), 11 deletions(-) diff --git a/driver/tsc_manager.py b/driver/tsc_manager.py index 21141a9..bbbd703 100644 --- a/driver/tsc_manager.py +++ b/driver/tsc_manager.py @@ -12,19 +12,22 @@ from driver.notifier import URL_EVENT, URL_RESPONSE Q_TIMEOUT = 2 +printer_map={} + +def get_queue_id(ip): + global printer_map + if ip in printer_map.keys(): + return printer_map[str(ip)]['queue_id'] + else: + return None + +def get_queue_command(): + global printer_map + return printer_map['queue_command'] + #lancia i thread, uno per stampante def main(q_in :queue.Queue, q_out :queue.Queue, q_comm: queue.Queue, logger: logging.getLogger): - printer_map={} - - def get_queue_id(ip): - if ip in printer_map.keys(): - return printer_map[str(ip)]['queue_id'] - else: - return None - - def get_queue_command(): - return q_comm - + global printer_map while True: try: comando = q_comm.get(block=True, timeout=Q_TIMEOUT) @@ -36,6 +39,7 @@ def main(q_in :queue.Queue, q_out :queue.Queue, q_comm: queue.Queue, logger: log # genera nuove code in ingresso per la nuova stampante q_in_prt = queue.Queue() q_cmd_prt = queue.Queue() + printer_map['queue_command'] = q_comm printer_map[par['ip']]['queue_id'] = q_in_prt # aggiungi la nuova coda al dict delle code printer_map[par['ip']]['port'] = par['port'] # lancia un thread stampante con la nuova coda ingresso