appsink: Add a client timeout, and handle eos separately

If no chunks are written to a client for 10 seconds, we end that stream and
clean it up. This is currently happening due to a bug, but might happen due to
bad/slow clients as well.

Instead of handling EOS from null samples, handle EOS through the signal
handler. This is a more reliable way of handling EOS, and also works when the
whole pipeline is torn down because the PUT stream ended.

1 files changed, 2 insertions, 0 deletions

diff --git a/src/lib.c b/src/lib.c
index cb24fa6..b36015d 100644
--- a/src/lib.c
+++ b/src/lib.c
@@ -90,6 +90,8 @@ stp_cleanup_transcode_client_ctx (TranscodeClientCtx *ctx)
 
   g_print (">>> Doing client cleanup.");
 
+  g_source_remove (ctx->timeout_handler_id);
+
   server_ctx->clients = g_list_remove (server_ctx->clients, ctx);
 
   /* Block sinkpad and srcpad, then unlink and remove */