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