- Edited
Hello, I want to pull the stream from the OAK-D-POE device itself.
I did run the file 'flash_bootloader.py' from depthai/examples with the tcp streaming pipeline with below code. It is successfull. Oak d poe Camera can now start on its own.
The code below is used from depthai-experiments/gen2-poe-tcp-streaming/.
host.py and oak.py
import depthai as dai
import time
# Start defining a pipeline
pipeline = dai.Pipeline()
camRgb = pipeline.createColorCamera()
camRgb.setIspScale(2,3)
videoEnc = pipeline.create(dai.node.VideoEncoder)
videoEnc.setDefaultProfilePreset(30, dai.VideoEncoderProperties.Profile.MJPEG)
camRgb.video.link(videoEnc.input)
script = pipeline.create(dai.node.Script)
script.setProcessor(dai.ProcessorType.LEON_CSS)
videoEnc.bitstream.link(script.inputs['frame'])
script.inputs['frame'].setBlocking(False)
script.inputs['frame'].setQueueSize(1)
script.setScript("""
import socket
import time
server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server.bind(("0.0.0.0", 5000))
server.listen()
node.warn("Server up")
while True:
conn, client = server.accept()
node.warn(f"Connected to client IP: {client}")
try:
while True:
pck = node.io["frame"].get()
data = pck.getData()
ts = pck.getTimestamp()
header = f"ABCDE " + str(ts.total_seconds()).ljust(18) + str(len(data)).ljust(8)
# node.warn(f'>{header}<')
conn.send(bytes(header, encoding='ascii'))
conn.send(data)
except Exception as e:
node.warn("Client disconnected")
""")
# with dai.Device(pipeline) as device:
# print("Connected")
# while True:
# time.sleep(1)
# Flash the app to the device
(f, bl) = dai.DeviceBootloader.getFirstAvailableDevice()
bootloader = dai.DeviceBootloader(bl)
progress = lambda p : print(f'Flashing progress: {p*100:.1f}%')
bootloader.flash(progress, pipeline)I understand host.py will remain same while i made changes to oak.py as above.
I have two Nvidia jetson boards with ubuntu 20.04 installed. I can successfully run host.py in one board and get the stream. The issue is i cannot run on the second jetson board parallelly. Seems like the second parallel call with host.py is getting stuck with no feed.
Please guide me on what is missing here. Attached the host.py code reference. Basically I have made no changes.
Thank you in advance for any help!