Closedown

script/local.py

@@ -26,8 +26,9 @@ _load(util.spec_from_file_location("zmq", PYHOME + "/lib/python" + PYVER + "/sit
 import zmq
 #zmq.LINGER = 0
 
+from bsread import source as bs_source
 
-from bsread import source, Source, PUB, SUB, PUSH, PULL, DEFAULT_DISPATCHER_URL
+from bsread import Source, PUB, SUB, PUSH, PULL, DEFAULT_DISPATCHER_URL
 
 from cam_server import CamClient, PipelineClient, ProxyClient, config
 

script/test/test_stream_out.py

@@ -14,12 +14,16 @@ viewer.show_stream("tcp://localhost:" + str(OUTPUT_PORT))
 
 pipeline_config = PipelineConfig("test_pipeline", parameters={"camera_name": "simulation", "function":"transparent"})
 
+source = None
 def send():
+    global source
     print ("Startint pipeline on port: ", OUTPUT_PORT)
     try:
         processing_pipeline(stop_event, statistics, parameter_queue, camera_client, pipeline_config, OUTPUT_PORT, MockBackgroundManager())
     except:
         traceback.print_exc()  
+    finally:
+        print ("Source -> " , source) 
         
 
 thread = Thread(target=send)