From e9facbe1992151de97e67aff7d8ebfcb6560615c Mon Sep 17 00:00:00 2001 From: gobbo_a Date: Thu, 25 Aug 2022 10:25:42 +0200 Subject: [PATCH] Startup --- script/test/test_stream_out.py | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/script/test/test_stream_out.py b/script/test/test_stream_out.py index fc94d24..2dd1b2c 100644 --- a/script/test/test_stream_out.py +++ b/script/test/test_stream_out.py @@ -8,20 +8,21 @@ parameter_queue = queue.Queue() statistics=Namespace() -OUTPUT_PORT = 12005 + viewer.show_stream("tcp://localhost:" + str(OUTPUT_PORT)) pipeline_config = PipelineConfig("test_pipeline", parameters={"camera_name": "simulation", "function":"transparent"}) -def send(): - print ("Startint pipeline on port: ", OUTPUT_PORT) +def send(port): + print ("Startint pipeline on port: ", port) try: - processing_pipeline(stop_event, statistics, parameter_queue, camera_client, pipeline_config, OUTPUT_PORT, MockBackgroundManager()) + processing_pipeline(stop_event, statistics, parameter_queue, camera_client, pipeline_config, port, MockBackgroundManager()) except: traceback.print_exc() -thread = Thread(target=send) +OUTPUT_PORT = 12005 +thread = Thread(target=send, args=(OUTPUT_PORT)) thread.start() with source(host="127.0.0.1", port=OUTPUT_PORT, mode=SUB, receive_timeout = 3000) as stream: