* aditional extra size. */
#define DEFAULT_EXTRA_SIZE_BYTES 10 * 1024 * 1024 /* 10 MB */
#define DEFAULT_EXTRA_SIZE_BUFFERS 5
+#ifdef TIZEN_FEATURE_MQ_MODIFICATION
+#define DEFAULT_EXTRA_SIZE_TIME 10 * GST_SECOND
+#else
#define DEFAULT_EXTRA_SIZE_TIME 3 * GST_SECOND
+#endif
#define DEFAULT_USE_BUFFERING FALSE
#define DEFAULT_LOW_PERCENT 10
GST_DEBUG_OBJECT (mq, "r_framerate is %d ", r_framerate);
- remaining_frame = (mq->stream_duration - cur_position) * r_framerate / GST_SECOND - size.visible; // packets num in video queue;
+ remaining_frame = (mq->stream_duration - cur_position) * r_framerate / GST_SECOND - size.visible; // packets num in video queue;
instant_throughput = size.visible * GST_SECOND / elapsed_time; // packets num / per seconds
GST_DEBUG_OBJECT (mq, "remaining_fram is %d, instant_throughput is %d",
remaining_frame, instant_throughput);
#define IS_FILLED(q, format, value) (((q)->max_size.format) != 0 && \
((q)->max_size.format) <= (value))
+#ifdef TIZEN_FEATURE_MQ_MODIFICATION
+#define IS_FILLED_EXTRA(q, format, value) (((((q)->extra_size.format) != 0) || (((q)->max_size.format) != 0)) && \
+ (((q)->extra_size.format)+((q)->max_size.format)) <= (value))
+#endif
/*
* GstSingleQueue functions
*/
return TRUE;
/* check time or bytes */
+#ifdef TIZEN_FEATURE_MQ_MODIFICATION
+ res = IS_FILLED_EXTRA (sq, time, sq->cur_time) || IS_FILLED (sq, bytes, bytes);
+#else
res = IS_FILLED (sq, time, sq->cur_time) || IS_FILLED (sq, bytes, bytes);
-
+#endif
return res;
}