use a appsrc to get more control over the socket

1 files changed, 47 insertions, 22 deletions

diff --git a/voctocore/experiments/failovertest.py b/voctocore/experiments/failovertest.py
index 3149197..5ebaa9a 100755
--- a/voctocore/experiments/failovertest.py
+++ b/voctocore/experiments/failovertest.py
@@ -1,7 +1,10 @@
 #!/usr/bin/python3
 import gi
+import time
 import signal
+from http.client import HTTPConnection
 from termcolor import colored
+from threading import Timer, Thread
 
 # import GStreamer and GTK-Helper classes
 gi.require_version('Gst', '1.0')
@@ -12,38 +15,60 @@ GObject.threads_init()
 Gst.init(None)
 loop = GLib.MainLoop()
 
-def busfunc(bus, message):
-	print(colored(message.src.get_name(), 'green'), message.type, message)
-	if message.type == Gst.MessageType.ERROR:
-		(err, debug) = message.parse_error()
-		print(colored(err, 'red'))
-		print(colored(debug, 'yellow'))
-		
-		if message.src.get_name() == 'http':
-			failover = p.get_by_name('failover')
-			failover.set_property('active-pad', failover.get_static_pad('sink_1'))
-
 # make killable by ctrl-c
 signal.signal(signal.SIGINT, signal.SIG_DFL)
 
-print("parse_launch")
+# parse_launch
 p = Gst.parse_launch("""
 	input-selector name=failover ! autovideosink
 
-	videotestsrc ! video/x-raw,width=1280,height=720 ! failover.sink_1
-	souphttpsrc name=http location="http://localhost/~peter/ED_1280.avi" ! decodebin ! failover.sink_0
+	appsrc name=src blocksize=4096 is-live=true block=true ! multipartdemux name=demux ! jpegparse ! jpegdec ! videoconvert ! failover.sink_1
+	videotestsrc ! video/x-raw,width=500,height=375 ! failover.sink_0
 """)
 
-print("add_watch")
-bus = p.get_bus()
-bus.add_signal_watch()
-bus.connect('message', busfunc)
+def failsafeVideoSource():
+	src = p.get_by_name('src')
+	dec = p.get_by_name('dec')
+	demux = p.get_by_name('demux')
+	failover = p.get_by_name('failover')
+	srcActive = True
+
+	while True:
+		print('connecting to framegrabber')
+		try:
+			con = HTTPConnection('beachcam.kdhnc.com', 80, timeout=3)
+			req = con.request('GET', '/mjpg/video.mjpg?camera=1')
+			res = con.getresponse()
+			srcActive = True
+
+			print('connected, switching to video')
+			failover.set_property('active-pad', failover.get_static_pad('sink_1'))
+
+			while srcActive:
+				chunk = res.read(4094)
+				chunklen = len(chunk)
+				print('read ', len(chunk), ' of ', 4096, ', closed=', res.isclosed())
+				
+				if chunklen > 0:
+					src.emit('push-buffer', Gst.Buffer.new_wrapped(chunk))
+				else:
+					srcActive = False
+		except:
+			print('exception')
+			srcActive = False
+
+		print('switching to failsave')
+		failover.set_property('active-pad', failover.get_static_pad('sink_0'))
+
+		print('sleeping before retry')
+		time.sleep(1)
 
-# print("add_watch")
-# httpbus = p.get_by_name('http').get_bus()
-# httpbus.add_watch(0, busfunc, None)
+fsThread = Thread(target=failsafeVideoSource)
+fsThread.deamon = True
+fsThread.start()
 
-print("set_state(PLAYING)")
+# set playing
 p.set_state(Gst.State.PLAYING)
 
+# start mainloop
 loop.run()