pshell_config/pide
0
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Startup

Browse Source
This commit is contained in:
gobbo_a
2022-08-25 10:25:42 +02:00
parent 7beeb21a2b
commit e9facbe199
1 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
script/test/test_stream_out.py
View File

@@ -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: