-
Notifications
You must be signed in to change notification settings - Fork 1
/
pinger.c
72 lines (59 loc) · 1.7 KB
/
pinger.c
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
/*
* pinger.c: centralised module that deals with sending SS_PING
* keepalives, to avoid replicating this code in multiple backends.
*/
#include "putty.h"
struct Pinger {
int interval;
bool pending;
unsigned long when_set, next;
Backend *backend;
};
static void pinger_schedule(Pinger *pinger);
static void pinger_timer(void *ctx, unsigned long now)
{
Pinger *pinger = (Pinger *)ctx;
if (pinger->pending && now == pinger->next) {
backend_special(pinger->backend, SS_PING, 0);
pinger->pending = false;
pinger_schedule(pinger);
}
}
static void pinger_schedule(Pinger *pinger)
{
unsigned long next;
if (!pinger->interval) {
pinger->pending = false; /* cancel any pending ping */
return;
}
next = schedule_timer(pinger->interval * TICKSPERSEC,
pinger_timer, pinger);
if (!pinger->pending ||
(next - pinger->when_set) < (pinger->next - pinger->when_set)) {
pinger->next = next;
pinger->when_set = timing_last_clock();
pinger->pending = true;
}
}
Pinger *pinger_new(Conf *conf, Backend *backend)
{
Pinger *pinger = snew(Pinger);
pinger->interval = conf_get_int(conf, CONF_ping_interval);
pinger->pending = false;
pinger->backend = backend;
pinger_schedule(pinger);
return pinger;
}
void pinger_reconfig(Pinger *pinger, Conf *oldconf, Conf *newconf)
{
int newinterval = conf_get_int(newconf, CONF_ping_interval);
if (conf_get_int(oldconf, CONF_ping_interval) != newinterval) {
pinger->interval = newinterval;
pinger_schedule(pinger);
}
}
void pinger_free(Pinger *pinger)
{
expire_timer_context(pinger);
sfree(pinger);
}