nicoboy/wireclaw
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Compare commits

base: nicoboy:822367ada86315daa4d6be16d579ca4ed78a7fc5
Branches Tags
nicoboy:master
...
compare: nicoboy:1c945fc9211358d5fd13f1a3488b82a350275f6b
Branches Tags
nicoboy:master

2 Commits
822367ada8 ... 1c945fc921

Author SHA1 Message Date
nicoboy
1c945fc921 fix: augmenter le timeout de sonde GStreamer à 15s (4s insuffisant) 
Le décodeur H.264 a besoin du temps d'attendre le premier keyframe/SPS-PPS,
surtout via Mycelium où la latence est plus élevée qu'en local. 4s faisait
parfois basculer en mode synthétique alors que le flux réel arrivait juste après.
 2026-07-01 15:56:27 +02:00
nicoboy
4857adb8da fix: pipeline GStreamer dual-stack IPv4+IPv6 pour réception flux Pi Zero 
Le flux RTP arrive maintenant via Mycelium en IPv6, mais udpsrc bindé
sur "::" seul ne reçoit pas les paquets IPv4 (pas de dual-stack sur ce
Jetson, IPV6_V6ONLY actif). Fusion de deux udpsrc (0.0.0.0 + ::) via
funnel pour accepter Freebox (dev, IPv4) et Mycelium (prod, IPv6).
 2026-07-01 15:36:11 +02:00
1 changed files with 10 additions and 4 deletions
Expand all files Collapse all files

12
receive_cam.py
View File

@ -28,14 +28,20 @@ MJPEG_QUALITY = 70
MODEL_PATH = Path(__file__).parent / "yolov8n.pt" MODEL_PATH = Path(__file__).parent / "yolov8n.pt"
# Pipeline GStreamer : RTP H.264 UDP → BGR frames # Pipeline GStreamer : RTP H.264 UDP → BGR frames
# Deux udpsrc (IPv4 0.0.0.0 + IPv6 ::) fusionnés par funnel : un socket IPv6 "::"
# seul ne reçoit pas les paquets IPv4 sur ce Jetson (IPV6_V6ONLY actif, pas de
# dual-stack), donc on écoute les deux familles en parallèle sur le même port.
# IPv4 : réseau local Freebox (dev) — IPv6 : Mycelium (prod, 4G).
GSTREAMER_PIPELINE = ( GSTREAMER_PIPELINE = (
"udpsrc port=5600 " "funnel name=f "
"! application/x-rtp,payload=96 " "! application/x-rtp,payload=96 "
"! rtph264depay " "! rtph264depay "
"! avdec_h264 " "! avdec_h264 "
"! videoconvert " "! videoconvert "
"! video/x-raw,format=BGR " "! video/x-raw,format=BGR "
"! appsink drop=true max-buffers=1 " "! appsink drop=true max-buffers=1 "
"udpsrc address=0.0.0.0 port=5600 ! f. "
"udpsrc address=:: port=5600 ! f."
) )
# Frame annotée partagée entre le thread de capture et le serveur MJPEG # Frame annotée partagée entre le thread de capture et le serveur MJPEG
@ -140,11 +146,11 @@ def open_capture() -> tuple[cv2.VideoCapture | None, str]:
1. Flux GStreamer UDP 5600 (Pi Zero) 1. Flux GStreamer UDP 5600 (Pi Zero)
2. Frame synthétique (pas de hardware) 2. Frame synthétique (pas de hardware)
""" """
print("[CAM] Sonde flux GStreamer UDP 5600 (timeout 4 s)...") print("[CAM] Sonde flux GStreamer UDP 5600 (timeout 15 s)...")
result: list = [] result: list = []
t = threading.Thread(target=_probe_gstreamer, args=(result,), daemon=True) t = threading.Thread(target=_probe_gstreamer, args=(result,), daemon=True)
t.start() t.start()
t.join(timeout=4) t.join(timeout=15)
if result: if result:
print("[CAM] Flux GStreamer UDP reçu.") print("[CAM] Flux GStreamer UDP reçu.")