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

Delay subscriptions created via the -j command line argument with 2 seconds.

Browse source
This commit is contained in:
Andreas Öman 2009-11-29 21:31:53 +00:00
parent 33f29241da
commit b0399bdeea
3 changed files with 9 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
src/main.c
View file

@ -394,7 +394,7 @@ main(int argc, char **argv)
rawts_init(rawts_input);
if(join_transport != NULL)
subscription_dummy_join(join_transport);
subscription_dummy_join(join_transport, 1);
#ifdef CONFIG_AVAHI
avahi_init();

9
src/subscriptions.c
View file

@ -343,7 +343,7 @@ static gtimer_t dummy_sub_timer;
static void
dummy_retry(void *opaque)
{
subscription_dummy_join(opaque);
subscription_dummy_join(opaque, 0);
free(opaque);
}
@ -351,11 +351,16 @@ dummy_retry(void *opaque)
*
*/
void
subscription_dummy_join(const char *id)
subscription_dummy_join(const char *id, int first)
{
th_transport_t *t = transport_find_by_identifier(id);
streaming_target_t *st;
if(first) {
gtimer_arm(&dummy_sub_timer, dummy_retry, strdup(id), 2);
return;
}
if(t == NULL) {
tvhlog(LOG_ERR, "subscription",
"Unable to dummy join %s, transport not found, retrying...", id);

2
src/subscriptions.h
View file

@ -70,7 +70,7 @@ void subscription_stop(th_subscription_t *s);
void subscription_unlink_transport(th_subscription_t *s);
void subscription_dummy_join(const char *id);
void subscription_dummy_join(const char *id, int first);
int subscriptions_active(void);