stv0g/tvheadend
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

htsp: some additional debug I added to help time channel zapping

Browse source
This commit is contained in:
Adam Sutton 2013-10-09 20:35:01 +01:00
parent 3f702cf2a4
commit a79dd7b7d8
1 changed files with 10 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
src/htsp_server.c
View file

@ -200,6 +200,8 @@ streaming_target_t *hs_transcoder;
uint32_t hs_filtered_streams[16]; // one bit per stream
int hs_first;
} htsp_subscription_t;
@ -1941,6 +1943,7 @@ readmsg:
htsp_authenticate(htsp, m);
if((method = htsmsg_get_str(m, "method")) != NULL) {
tvhtrace("htsp", "%s - method %s", htsp->htsp_logname, method);
for(i = 0; i < NUM_METHODS; i++) {
if(!strcmp(method, htsp_methods[i].name)) {
@ -2475,6 +2478,7 @@ htsp_subscription_start(htsp_subscription_t *hs, const streaming_start_t *ss)
htsmsg_t *sourceinfo = htsmsg_create_map();
int i;
const source_info_t *si = &ss->ss_si;
tvhdebug("htsp", "%s - subscription start", hs->hs_htsp->htsp_logname);
for(i = 0; i < ss->ss_num_components; i++) {
const streaming_start_component_t *ssc = &ss->ss_components[i];
@ -2540,6 +2544,7 @@ htsp_subscription_stop(htsp_subscription_t *hs, const char *err)
htsmsg_t *m = htsmsg_create_map();
htsmsg_add_str(m, "method", "subscriptionStop");
htsmsg_add_u32(m, "subscriptionId", hs->hs_sid);
tvhdebug("htsp", "%s - subscription stop", hs->hs_htsp->htsp_logname);
if(err != NULL)
htsmsg_add_str(m, "status", err);
@ -2604,6 +2609,7 @@ static void
htsp_subscription_speed(htsp_subscription_t *hs, int speed)
{
htsmsg_t *m = htsmsg_create_map();
tvhdebug("htsp", "%s - subscription speed", hs->hs_htsp->htsp_logname);
htsmsg_add_str(m, "method", "subscriptionSpeed");
htsmsg_add_u32(m, "subscriptionId", hs->hs_sid);
htsmsg_add_u32(m, "speed", speed);
@ -2617,6 +2623,7 @@ static void
htsp_subscription_skip(htsp_subscription_t *hs, streaming_skip_t *skip)
{
htsmsg_t *m = htsmsg_create_map();
tvhdebug("htsp", "%s - subscription skip", hs->hs_htsp->htsp_logname);
htsmsg_add_str(m, "method", "subscriptionSkip");
htsmsg_add_u32(m, "subscriptionId", hs->hs_sid);
@ -2665,6 +2672,9 @@ htsp_streaming_input(void *opaque, streaming_message_t *sm)
switch(sm->sm_type) {
case SMT_PACKET:
if (!hs->hs_first)
tvhdebug("htsp", "%s - first packet", hs->hs_htsp->htsp_logname);
hs->hs_first = 1;
htsp_stream_deliver(hs, sm->sm_data);
// reference is transfered
sm->sm_data = NULL;