HTSP: Allow a subscriber to set queue depth

diff --git a/src/htsp.c b/src/htsp.c
index f371183c8175092a74cb66da56480baaa1fd32c9..531e9fffcb079425b5817010e1d157a97ed51b95 100644 (file)
--- a/src/htsp.c
+++ b/src/htsp.c
@@ -171,8 +171,12 @@ typedef struct htsp_subscription {
 
   int hs_90khz;
 
+  int hs_queue_depth;
+
 } htsp_subscription_t;
 
+#define HTSP_DEFAULT_QUEUE_DEPTH 500000
+
 /* **************************************************************************
  * Support routines
  * *************************************************************************/
@@ -1133,6 +1137,8 @@ htsp_method_subscribe(htsp_connection_t *htsp, htsmsg_t *in)
 
   hs->hs_htsp = htsp;
   hs->hs_90khz = req90khz;
+  hs->hs_queue_depth = htsmsg_get_u32_or_default(in, "queueDepth",
+                                                HTSP_DEFAULT_QUEUE_DEPTH);
   htsp_init_queue(&hs->hs_q, 0);
 
   hs->hs_sid = sid;
@@ -1739,9 +1745,9 @@ htsp_stream_deliver(htsp_subscription_t *hs, th_pkt_t *pkt)
   int64_t ts;
   int qlen = hs->hs_q.hmq_payload;
 
-  if((qlen > 500000 && pkt->pkt_frametype == PKT_B_FRAME) ||
-     (qlen > 750000 && pkt->pkt_frametype == PKT_P_FRAME) || 
-     (qlen > 1500000)) {
+  if((qlen > hs->hs_queue_depth     && pkt->pkt_frametype == PKT_B_FRAME) ||
+     (qlen > hs->hs_queue_depth * 2 && pkt->pkt_frametype == PKT_P_FRAME) || 
+     (qlen > hs->hs_queue_depth * 3)) {
 
     hs->hs_dropstats[pkt->pkt_frametype]++;