mssdemux: add a maximum error count for downloads

mssdemux will tolerate a few download errors before emitting an
error message to the bus

diff --git a/ext/smoothstreaming/gstmssdemux.c b/ext/smoothstreaming/gstmssdemux.c
index 8127a4db93eff5d2cd1041c405003849f2fc47c0..0b4e6229c42945214854516e9557cba60b07f21d 100644 (file)
--- a/ext/smoothstreaming/gstmssdemux.c
+++ b/ext/smoothstreaming/gstmssdemux.c
@@ -84,6 +84,7 @@ GST_DEBUG_CATEGORY (mssdemux_debug);
 #define DEFAULT_BITRATE_LIMIT 0.8
 
 #define DOWNLOAD_RATE_MAX_HISTORY_LENGTH 5
 #define DEFAULT_BITRATE_LIMIT 0.8
 
 #define DOWNLOAD_RATE_MAX_HISTORY_LENGTH 5

+#define MAX_DOWNLOAD_ERROR_COUNT 3

 
 enum
 {
 
 enum
 {


@@ -1223,6 +1224,8 @@ gst_mss_demux_download_loop (GstMssDemuxStream * stream)
       break;
   }
 
       break;
   }
 

+  stream->download_error_count = 0;
+

   if (buffer) {
     gst_mss_stream_advance_fragment (stream->manifest_stream);
   }
   if (buffer) {
     gst_mss_stream_advance_fragment (stream->manifest_stream);
   }


@@ -1241,7 +1244,11 @@ eos:
 error:
   {
     GST_WARNING_OBJECT (mssdemux, "Error while pushing fragment");
 error:
   {
     GST_WARNING_OBJECT (mssdemux, "Error while pushing fragment");

-    gst_task_pause (stream->download_task);
+    if (++stream->download_error_count >= DOWNLOAD_RATE_MAX_HISTORY_LENGTH) {
+      GST_ELEMENT_ERROR (mssdemux, RESOURCE, NOT_FOUND,
+          (_("Couldn't download fragments")),
+          ("fragment downloading has failed too much consecutive times"));
+    }

     return;
   }
 }
     return;
   }
 }

diff --git a/ext/smoothstreaming/gstmssdemux.h b/ext/smoothstreaming/gstmssdemux.h
index 2c48aac364c295a5e36ee8ec4e4ad26d3a72cc1d..5e4f18502c43f25df6f76c9b4fa25f2c99a6bc01 100644 (file)
--- a/ext/smoothstreaming/gstmssdemux.h
+++ b/ext/smoothstreaming/gstmssdemux.h
@@ -74,6 +74,8 @@ struct _GstMssDemuxStream {
   gboolean have_data;
 
   GstDownloadRate download_rate;
   gboolean have_data;
 
   GstDownloadRate download_rate;

+
+  guint download_error_count;

 };
 
 struct _GstMssDemux {
 };
 
 struct _GstMssDemux {