blob: 6242d381680156e8a3de18146c1bb3a1a26f3d1a (
plain)
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
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
|
/*
* hbeat.c --
*
* Simple heartbeating.
*
*/
#include <string.h>
#include <stdlib.h>
#include <sys/types.h>
#include <time.h>
#include "btime.h"
#include "hbeat.h"
struct hbeat_s {
char *host;
int max_timeout;
hbeat_state_t rhost_state;
unsigned int last_rhost_btime;
time_t start_quiet_time;
};
/*
* hbeat_init --
*
* Init a heartbeat to host, with max_timeout as supplied.
*
* Returns:
* A hbeat handle, or NULL on error;
*/
hbeat_t
hbeat_init(const char *host, int max_timeout)
{
struct hbeat_s *hbeatp;
hbeatp = malloc(sizeof *hbeatp);
if (!hbeatp) {
return NULL;
}
hbeatp->host = strdup(host);
hbeatp->max_timeout = max_timeout;
hbeatp->rhost_state = HOST_ALIVE;
hbeatp->last_rhost_btime = 0;
hbeatp->start_quiet_time = 0;
return hbeatp;
}
/*
* hbeat_free --
*
* Free a hbeat handle.
*/
void
hbeat_free(hbeat_t hbh)
{
struct hbeat_s *hbeatp = hbh;
free(hbeatp->host);
free(hbeatp);
}
/*
* hbeat --
*
* Attempt to contact host in the hbeat handle, run the hbeat
* "state machine" to decide if we the host is still "alive."
*
* Returns:
* 1 if host has been active or responded withing max_timeout secs.
* 0 if host is dead, no response for > max_timeout secs.
*/
unsigned int
hbeat(hbeat_t hbh)
{
struct hbeat_s *hbeatp = hbh;
unsigned int hbeat;
time_t current_time;
int retval;
/* User disabled heart beating */
if (!hbeatp->max_timeout) {
hbeatp->rhost_state = HOST_HBEAT_DISABLED;
return 1;
}
hbeat = btime(hbeatp->host);
current_time = time(NULL);
if (!hbeat) {
switch (hbeatp->rhost_state) {
case HOST_ALIVE:
hbeatp->rhost_state = HOST_QUIET;
hbeatp->start_quiet_time = time(NULL);
retval = 1;
break;
case HOST_QUIET:
if (current_time - hbeatp->start_quiet_time
> hbeatp->max_timeout) {
hbeatp->rhost_state = HOST_TIMEOUT;
retval = 0;
} else {
retval = 1;
}
break;
case HOST_TIMEOUT:
case HOST_REBOOT:
retval = 0;
break;
case HOST_HBEAT_DISABLED:
retval = 1;
break;
}
}
if (hbeat) {
if (hbeatp->rhost_state == HOST_REBOOT) {
retval = 0;
} else {
hbeatp->last_rhost_btime = hbeat;
hbeatp->rhost_state = HOST_ALIVE;
hbeatp->start_quiet_time = 0;
retval = 1;
if (abs(hbeat - hbeatp->last_rhost_btime) > 5) {
hbeatp->rhost_state = HOST_REBOOT;
retval = 0;
}
}
}
return retval;
}
hbeat_state_t
hbeat_getstate(hbeat_t hbh)
{
return ((struct hbeat_s *)hbh)->rhost_state;
}
void
hbeat_setstate(hbeat_t hbh, hbeat_state_t state)
{
((struct hbeat_s *)hbh)->rhost_state = state;
return;
}
|
