aboutsummaryrefslogtreecommitdiff
path: root/voctocore/lib/vsource.py
diff options
context:
space:
mode:
Diffstat (limited to 'voctocore/lib/vsource.py')
-rw-r--r--voctocore/lib/vsource.py54
1 files changed, 54 insertions, 0 deletions
diff --git a/voctocore/lib/vsource.py b/voctocore/lib/vsource.py
new file mode 100644
index 0000000..2296eac
--- /dev/null
+++ b/voctocore/lib/vsource.py
@@ -0,0 +1,54 @@
+#!/usr/bin/python3
+import logging
+from gi.repository import Gst
+
+from lib.config import Config
+from lib.tcpsingleconnection import TCPSingleConnection
+
+class VSource(TCPSingleConnection):
+ def __init__(self, name, port):
+ self.log = logging.getLogger('VSource['+name+']')
+ super().__init__(port)
+
+ self.name = name
+
+ def on_accepted(self, conn, addr):
+ pipeline = """
+ fdsrc fd={fd} !
+ matroskademux !
+ {vcaps} !
+ intervideosink channel=video_{name}
+ """.format(
+ fd=conn.fileno(),
+ name=self.name,
+ vcaps=Config.get('mix', 'videocaps')
+ )
+
+ self.log.debug('Launching Source-Pipeline:\n%s', pipeline)
+ self.receiverPipeline = Gst.parse_launch(pipeline)
+
+ self.log.debug('Binding End-of-Stream-Signal on Source-Pipeline')
+ self.receiverPipeline.bus.add_signal_watch()
+ self.receiverPipeline.bus.connect("message::eos", self.on_eos)
+ self.receiverPipeline.bus.connect("message::error", self.on_error)
+
+ self.receiverPipeline.set_state(Gst.State.PLAYING)
+
+
+ def on_eos(self, bus, message):
+ self.log.debug('Received End-of-Stream-Signal on Source-Pipeline')
+ if self.currentConnection is not None:
+ self.disconnect()
+
+ def on_error(self, bus, message):
+ self.log.debug('Received Error-Signal on Source-Pipeline')
+ (error, debug) = message.parse_error()
+ self.log.debug('Error-Details: #%u: %s', error.code, debug)
+
+ if self.currentConnection is not None:
+ self.disconnect()
+
+ def disconnect(self):
+ self.receiverPipeline.set_state(Gst.State.NULL)
+ self.receiverPipeline = None
+ self.close_connection()