2 * pinger.c: centralised module that deals with sending TS_PING
3 * keepalives, to avoid replicating this code in multiple backends.
11 unsigned long when_set, next;
16 static void pinger_schedule(Pinger pinger);
18 static void pinger_timer(void *ctx, unsigned long now)
20 Pinger pinger = (Pinger)ctx;
22 if (pinger->pending && now == pinger->next) {
23 pinger->back->special(pinger->backhandle, TS_PING);
24 pinger->pending = FALSE;
25 pinger_schedule(pinger);
29 static void pinger_schedule(Pinger pinger)
33 if (!pinger->interval) {
34 pinger->pending = FALSE; /* cancel any pending ping */
38 next = schedule_timer(pinger->interval * TICKSPERSEC,
39 pinger_timer, pinger);
40 if (!pinger->pending ||
41 (next - pinger->when_set) < (pinger->next - pinger->when_set)) {
43 pinger->when_set = timing_last_clock();
44 pinger->pending = TRUE;
48 Pinger pinger_new(Conf *conf, Backend *back, void *backhandle)
50 Pinger pinger = snew(struct pinger_tag);
52 pinger->interval = conf_get_int(conf, CONF_ping_interval);
53 pinger->pending = FALSE;
55 pinger->backhandle = backhandle;
56 pinger_schedule(pinger);
61 void pinger_reconfig(Pinger pinger, Conf *oldconf, Conf *newconf)
63 int newinterval = conf_get_int(newconf, CONF_ping_interval);
64 if (conf_get_int(oldconf, CONF_ping_interval) != newinterval) {
65 pinger->interval = newinterval;
66 pinger_schedule(pinger);
70 void pinger_free(Pinger pinger)
72 expire_timer_context(pinger);