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

Cleanup

Browse source
This commit is contained in:
Andreas Öman 2008-05-17 09:26:03 +00:00
parent 8557316d41
commit 70a03bb900
1 changed files with 8 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
serviceprobe.c
View file

@ -66,8 +66,11 @@ sp_done_callback(void *aux, int64_t now)
sp_t *sp = aux;
th_subscription_t *s = sp->sp_s;
if(s != NULL)
if(s != NULL) {
assert(sp == sp_current);
sp_current = NULL;
subscription_unsubscribe(s);
}
serviceprobe_engage();
@ -132,7 +135,6 @@ sp_status_callback(struct th_subscription *s, int status, void *opaque)
}
/**
* Called when a subscription gets/loses access to a transport
*/
@ -166,27 +168,24 @@ serviceprobe_start(void *aux, int64_t now)
assert(sp_current == NULL);
printf("Engage ...: ");
if((sp = TAILQ_FIRST(&probequeue)) == NULL) {
printf("Q empty\n");
if((sp = TAILQ_FIRST(&probequeue)) == NULL)
return;
}
s = sp->sp_s = calloc(1, sizeof(th_subscription_t));
t = sp->sp_t;
sp_current = sp;
s->ths_title = strdup("probe");
s->ths_weight = INT32_MAX;
s->ths_opaque = sp;
s->ths_callback = sp_subscription_callback;
LIST_INSERT_HEAD(&subscriptions, s, ths_global_link);
if(t->tht_runstatus != TRANSPORT_RUNNING)
transport_start(t, INT32_MAX);
printf("Starting %s\n", t->tht_svcname);
s->ths_transport = t;
LIST_INSERT_HEAD(&t->tht_subscriptions, s, ths_transport_link);