From c738cc2b7185bc414626ac350e8a985e1d298f34 Mon Sep 17 00:00:00 2001 From: gobbo_a Date: Wed, 24 Aug 2022 15:34:53 +0200 Subject: [PATCH] Closedown --- script/local.py | 3 ++- script/test/test_stream_out.py | 4 ++++ 2 files changed, 6 insertions(+), 1 deletion(-) diff --git a/script/local.py b/script/local.py index 3caa26c..5d90fe1 100644 --- a/script/local.py +++ b/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 diff --git a/script/test/test_stream_out.py b/script/test/test_stream_out.py index 77892fc..9897e65 100644 --- a/script/test/test_stream_out.py +++ b/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)