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-26 11:04:05 +02:00
parent 5382e7c65a
commit fcb1a34d26
2 changed files with 12 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
script/local.py
View File

@@ -114,7 +114,7 @@ parameter_queue = None
statistics =None
current_pipeline = None
def start_pipeline(name, pars, port=DEFAULT_PIPELINE_PORT):
def start_pipeline(name, parameters, port=DEFAULT_PIPELINE_PORT):
global stop_event, parameter_queue, statistics
if name is None:
raise Exception("Pipeline name undefined")
@@ -123,6 +123,7 @@ def start_pipeline(name, pars, port=DEFAULT_PIPELINE_PORT):
stop_event = threading.Event()
parameter_queue = queue.Queue()
statistics = Namespace()
pipeline_config = PipelineConfig(name, parameters=parameters)
def send(port):
print ("Startint pipeline ", name, " on port: ", port)
try:

10
script/test/test_pipeline2.py Normal file
View File

@@ -0,0 +1,10 @@
#viewer.show_stream("tcp://localhost:" + str(DEFAULT_PIPELINE_PORT))
#pipeline_config = PipelineConfig("test_pipeline", parameters={"camera_name": "simulation", "function":"transparent"})
#start_pipeline("test_pipeline", {"camera_name": "simulation", "function":"transparent"})
with source(host="127.0.0.1", port=DEFAULT_PIPELINE_PORT, mode=SUB, receive_timeout = 3000) as stream:
data = stream.receive()
if not data:
raise Exception("Received None message.")
print (data.data.data.keys())