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

dbus: epggrab ota - add next time ota epg notifications

Browse source
This commit is contained in:
Jaroslav Kysela 2014-08-06 21:35:12 +02:00
parent 0cd02f6df0
commit 7be9bbda2a
1 changed files with 18 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

24
src/epggrab/otamux.c
View file

@ -25,6 +25,7 @@
#include "input.h"
#include "subscriptions.h"
#include "cron.h"
#include "dbus.h"
#include <string.h>
#include <sys/types.h>
@ -523,6 +524,17 @@ done:
* Start times management
*/
static void
epggrab_ota_start_cb ( void *p );
static void
epggrab_ota_next_arm( time_t next )
{
tvhtrace("epggrab", "next ota start event in %li seconds", next - time(NULL));
gtimer_arm_abs(&epggrab_ota_start_timer, epggrab_ota_start_cb, NULL, next);
dbus_emit_signal_s64("epggrab_ota_next", next);
}
static void
epggrab_ota_start_cb ( void *p )
{
@ -535,10 +547,8 @@ epggrab_ota_start_cb ( void *p )
epggrab_ota_kick(1);
pthread_mutex_lock(&epggrab_ota_mutex);
if (!cron_multi_next(epggrab_ota_cron_multi, dispatch_clock, &next)) {
tvhtrace("epggrab", "next ota start event in %li seconds", next - time(NULL));
gtimer_arm_abs(&epggrab_ota_start_timer, epggrab_ota_start_cb, NULL, next);
}
if (!cron_multi_next(epggrab_ota_cron_multi, dispatch_clock, &next))
epggrab_ota_next_arm(next);
pthread_mutex_unlock(&epggrab_ota_mutex);
}
@ -553,9 +563,9 @@ epggrab_ota_arm ( time_t last )
/* do not trigger the next EPG scan for 1/2 hour */
if (last != (time_t)-1 && last + 1800 > next)
next = last + 1800;
tvhtrace("epggrab", "next ota start event in %li seconds", next - time(NULL));
gtimer_arm_abs(&epggrab_ota_start_timer, epggrab_ota_start_cb, NULL, next);
epggrab_ota_next_arm(next);
}
pthread_mutex_unlock(&epggrab_ota_mutex);
}
@ -748,6 +758,8 @@ epggrab_ota_post ( void )
/* Init timer (call after full init - wait for network tuners) */
if (epggrab_ota_initial) {
/* notify another system layers, that we will do EPG OTA */
dbus_emit_signal_s64("epggrab_ota_next", time(NULL) + 15);
epggrab_ota_pending_flag = 1;
epggrab_ota_kick(15);
t = time(NULL);