diff options
| -rw-r--r-- | voctocore/lib/avrawoutput.py | 5 |
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') |