sender.py

#! /usr/bin/env python3
from threading import Thread

import gi
import sys
import os
from time import sleep

gi.require_version("Gst", "1.0")
from gi.repository import Gst, GLib
Gst.init(sys.argv[1:])


def isVideo(element):
    return True if element.startswith("video") else False

def getCamsAndPipes():
    cams = filter(isVideo, os.listdir("/dev/")) # gets list of video devices if isVideo finds them in os list
    pipelines = []

    for i, cam in enumerate(cams):
        pipStr = 'v4l2src device="/dev/{}" !  image/jpeg,width=640,framerate=15/1,rate=15 ! rtpjpegpay !  udpsink host=192.168.2.255 port=5{}00'.format(cam, i)

        pipeline = Gst.parse_launch(pipStr)
        pipelines.append(pipeline)

        print("PIPELINE : " + pipStr)

    for pipeline in pipelines:
        if not pipeline:
            print("pipeline error")
            sys.exit(1)

    return pipelines

def cleanPipelins(pipelines):
    for i, pipe in enumerate(pipelines):
        pipe.set_state(Gst.State.NULL)
        print("- pipeline " + str(i) + " resetting to null")

def startPipes(pipelines = getCamsAndPipes()):


    for i, pipeline in enumerate(pipelines):
        ret = pipeline.set_state(Gst.State.PLAYING)
        if ret == Gst.StateChangeReturn.FAILURE:
            print("pipeline {} couldn't started.".format(i))
        else:
            print("pipeline {} started.".format(i))

    return pipelines
            
def mainloop():
    while True:
        sleep(0.01)


main_loop = GLib.MainLoop()
thread = Thread(target=main_loop.run, daemon=True)

thread.start()
pipes = startPipes()

if len(pipes) < 2:
    print("Not enough cams present, exiting")
    exit(1)

try:
    mainloop()
    
except KeyboardInterrupt:
    print("\nexiting...")

finally:
    cleanPipelins(pipes)
    main_loop.quit()
    exit(0)