feat: threaded loading back

2019-07-08 23:24:08 +02:00
parent 7cf0f20ffb
commit bb16dc9524
3 changed files with 8 additions and 6 deletions
--- a/client.py
+++ b/client.py
@ -416,10 +416,11 @@ def net_worker(ctx, store, pipe, serial_product, serial_feed, stop_event,externa

                    msg.store(agent.property_map)

-                    params = []
-                    params.append(msg.key)
-                    params.append(msg.body)
-                    external_executor.put((helpers.load,params))
+                    # params = []
+                    # params.append(msg.key)
+                    # params.append(msg.body)
+                    # external_executor.put((helpers.load,params))
+                    net_product.put(('LOAD', msg.key, msg.body))
        
        # Serialisation thread  => Net thread
        if not net_feed.empty():