Added examples

examples/Sync/demux_message_group.py

@@ -0,0 +1,56 @@
+import depthai as dai
+import time
+
+pipeline = dai.Pipeline()
+
+script1 = pipeline.create(dai.node.Script)
+script1.setScript("""
+from time import sleep
+
+while True:
+    sleep(1)
+    b = Buffer(512)
+    b.setData(bytes(4 * [i for i in range(0, 128)]))
+    b.setTimestamp(Clock.now())
+    node.io['out'].send(b)
+""")
+
+script2 = pipeline.create(dai.node.Script)
+script2.setScript("""
+from time import sleep
+
+while True:
+    sleep(0.3)
+    b = Buffer(512)
+    b.setData(bytes(4 * [i for i in range(128, 256)]))
+    b.setTimestamp(Clock.now())
+    node.io['out'].send(b)
+""")
+
+sync = pipeline.create(dai.node.Sync)
+sync.setSyncThresholdMs(100)
+
+demux = pipeline.create(dai.node.MessageDemux)
+
+xout1 = pipeline.create(dai.node.XLinkOut)
+xout1.setStreamName("xout1")
+xout2 = pipeline.create(dai.node.XLinkOut)
+xout2.setStreamName("xout2")
+
+script1.outputs["out"].link(sync.inputs["s1"])
+script2.outputs["out"].link(sync.inputs["s2"])
+sync.out.link(demux.input)
+demux.outputs["s1"].link(xout1.input)
+demux.outputs["s2"].link(xout2.input)
+
+with dai.Device(pipeline) as device:
+    print("Start")
+    q1 = device.getOutputQueue("xout1", maxSize=10, blocking=True)
+    q2 = device.getOutputQueue("xout2", maxSize=10, blocking=True)
+    while True:
+        bufS1 = q1.get()
+        bufS2 = q2.get()
+        print(f"Buffer 1 timestamp: {bufS1.getTimestamp()}")
+        print(f"Buffer 2 timestamp: {bufS2.getTimestamp()}")
+        print("----------")
+        time.sleep(0.2)

examples/Sync/sync_scripts.py

@@ -0,0 +1,52 @@
+import depthai as dai
+import time
+
+pipeline = dai.Pipeline()
+
+script1 = pipeline.create(dai.node.Script)
+script1.setScript("""
+from time import sleep
+
+while True:
+    sleep(1)
+    b = Buffer(512)
+    b.setData(bytes(4 * [i for i in range(0, 128)]))
+    b.setTimestamp(Clock.now())
+    node.io['out'].send(b)
+""")
+
+script2 = pipeline.create(dai.node.Script)
+script2.setScript("""
+from time import sleep
+
+while True:
+    sleep(0.3)
+    b = Buffer(512)
+    b.setData(bytes(4 * [i for i in range(128, 256)]))
+    b.setTimestamp(Clock.now())
+    node.io['out'].send(b)
+""")
+
+sync = pipeline.create(dai.node.Sync)
+sync.setSyncThresholdMs(100)
+
+xout = pipeline.create(dai.node.XLinkOut)
+xout.setStreamName("xout")
+
+sync.out.link(xout.input)
+
+script1.outputs["out"].link(sync.inputs["s1"])
+script2.outputs["out"].link(sync.inputs["s2"])
+
+# script1.outputs["out"].link(xout.input)
+
+with dai.Device(pipeline) as device:
+    print("Start")
+    q = device.getOutputQueue("xout", maxSize=10, blocking=True)
+    while True:
+        grp = q.get()
+        print(f"Buffer 1 timestamp: {grp["s1"].getTimestamp()}")
+        print(f"Buffer 2 timestamp: {grp["s2"].getTimestamp()}")
+        print(f"Time interval between messages: {grp.getIntervalNs() / 1e6}ms")
+        print("----------")
+        time.sleep(0.2)

src/pipeline/datatype/MessageGroupBindings.cpp

@@ -51,6 +51,8 @@ void bind_message_group(pybind11::module& m, void* pCallstack){
         })
         .def("isSynced", &MessageGroup::isSynced, DOC(dai, MessageGroup, isSynced))
         .def("getIntervalNs", &MessageGroup::getIntervalNs, DOC(dai, MessageGroup, getIntervalNs))
+        .def("getNumMessages", &MessageGroup::getNumMessages, DOC(dai, MessageGroup, getNumMessages))
+        .def("getMessageNames", &MessageGroup::getMessageNames, DOC(dai, MessageGroup, getMessageNames))
         .def("getTimestamp", &MessageGroup::Buffer::getTimestamp, DOC(dai, Buffer, getTimestamp))
         .def("getTimestampDevice", &MessageGroup::Buffer::getTimestampDevice, DOC(dai, Buffer, getTimestampDevice))
         .def("getSequenceNum", &MessageGroup::Buffer::getSequenceNum, DOC(dai, Buffer, getSequenceNum))