From ba7ec12f9149ef8243bbe9659ecb8b04cee1ca48 Mon Sep 17 00:00:00 2001 From: Jaroslav Kysela Date: Wed, 18 Feb 2015 19:50:27 +0100 Subject: [PATCH] HTSP server: add errors field to packet statistics --- src/htsp_server.c | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/src/htsp_server.c b/src/htsp_server.c index 1b524760..ca1b1a44 100644 --- a/src/htsp_server.c +++ b/src/htsp_server.c @@ -209,6 +209,8 @@ typedef struct htsp_subscription { int hs_first; + uint32_t hs_data_errors; + } htsp_subscription_t; @@ -3234,8 +3236,11 @@ htsp_stream_deliver(htsp_subscription_t *hs, th_pkt_t *pkt) int qlen = hs->hs_q.hmq_payload; size_t payloadlen; - if(pkt->pkt_payload == NULL) + if (pkt->pkt_err) + hs->hs_data_errors += pkt->pkt_err; + if(pkt->pkt_payload == NULL) { return; + } if(!htsp_is_stream_enabled(hs, pkt->pkt_componentindex)) { pkt_ref_dec(pkt); @@ -3295,6 +3300,8 @@ htsp_stream_deliver(htsp_subscription_t *hs, th_pkt_t *pkt) htsmsg_add_u32(m, "subscriptionId", hs->hs_sid); htsmsg_add_u32(m, "packets", hs->hs_q.hmq_length); htsmsg_add_u32(m, "bytes", hs->hs_q.hmq_payload); + if (hs->hs_data_errors) + htsmsg_add_u32(m, "errors", hs->hs_data_errors); /** * Figure out real time queue delay