summaryrefslogtreecommitdiff
path: root/voctocore/lib/videosrcmirror.py
diff options
context:
space:
mode:
Diffstat (limited to 'voctocore/lib/videosrcmirror.py')
-rw-r--r--voctocore/lib/videosrcmirror.py66
1 files changed, 0 insertions, 66 deletions
diff --git a/voctocore/lib/videosrcmirror.py b/voctocore/lib/videosrcmirror.py
deleted file mode 100644
index 8fb911d..0000000
--- a/voctocore/lib/videosrcmirror.py
+++ /dev/null
@@ -1,66 +0,0 @@
-#!/usr/bin/python3
-import logging, socket
-from gi.repository import GObject, Gst
-
-from lib.config import Config
-
-class VideoSrcMirror(object):
- log = logging.getLogger('VideoSrcMirror')
-
- name = None
- port = None
- caps = None
-
- boundSocket = None
-
- receiverPipelines = []
- currentConnections = []
-
- def __init__(self, name, port, caps):
- self.log = logging.getLogger('VideoSrcMirror['+name+']')
-
- self.name = name
- self.port = port
- self.caps = caps
-
- self.log.debug('Binding to Mirror-Socket on [::]:%u', port)
- self.boundSocket = socket.socket(socket.AF_INET6)
- self.boundSocket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
- self.boundSocket.setsockopt(socket.IPPROTO_IPV6, socket.IPV6_V6ONLY, False)
- self.boundSocket.bind(('::', port))
- self.boundSocket.listen(1)
-
- self.log.debug('Setting GObject io-watch on Socket')
- GObject.io_add_watch(self.boundSocket, GObject.IO_IN, self.on_connect)
-
- def on_connect(self, sock, *args):
- conn, addr = sock.accept()
- self.log.info("incomming connection from %s", addr)
-
- pipeline = """
- intervideosrc channel={name}_mirror !
- {caps} !
- textoverlay text={name}_mirror halignment=left valignment=top ypad=125 !
- gdppay !
- fdsink fd={fd}
- """.format(
- fd=conn.fileno(),
- name=self.name,
- caps=self.caps
- )
- self.log.debug('Launching Mirror-Receiver-Pipeline:\n%s', pipeline)
- receiverPipeline = Gst.parse_launch(pipeline)
-
- self.log.debug('Binding End-of-Stream-Signal on Source-Receiver-Pipeline')
- receiverPipeline.bus.add_signal_watch()
- receiverPipeline.bus.connect("message::eos", self.on_disconnect)
-
- receiverPipeline.set_state(Gst.State.PLAYING)
-
- self.receiverPipelines.append(receiverPipeline)
- self.currentConnections.append(conn)
-
- return True
-
- def on_disconnect(self, bus, message):
- self.log.info('Received End-of-Stream-Signal on Source-Receiver-Pipeline')