issue a warning when a client is too slow and about to get disconnected, #16

1 files changed, 5 insertions, 0 deletions

diff --git a/voctocore/lib/avrawoutput.py b/voctocore/lib/avrawoutput.py
index f7dcdf4..ee77c4d 100644
--- a/voctocore/lib/avrawoutput.py
+++ b/voctocore/lib/avrawoutput.py
@@ -58,7 +58,12 @@ class AVRawOutput(TCPMultiConnection):
 				self.log.debug('fd %u removed from multifdsink', fileno)
 				self.close_connection(conn)
 
+		def on_about_to_disconnect(multifdsink, fileno, status):
+			if fileno == conn.fileno() and status == 3: # Gst.MultiHandleSinkClientStatus.Slow
+				self.log.warning('about to remove fd %u from multifdsink because it is too slow!', fileno)
+
 		fdsink.connect('client-fd-removed', on_disconnect)
+		fdsink.connect('client-removed', on_about_to_disconnect)
 
 	def on_eos(self, bus, message):
 		self.log.debug('Received End-of-Stream-Signal on Output-Pipeline')