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
|
#include <ev.h>
#include "log.h"
#include "pingu_burst.h"
#include "pingu_host.h"
#include "pingu_ping.h"
void pingu_host_set_status(struct pingu_host *host, int status)
{
const char *action;
if (host->status == status) {
log_debug("%s: status is still %s", host->host, status);
return;
}
host->status = status;
log_info("%s: new status: %s", host->host, status);
switch (host->status) {
case 0:
action = host->down_action;
break;
case 1:
action = host->up_action;
break;
}
log_debug("TODO: execute %s", action);
}
int pingu_host_verify_status(struct ev_loop *loop, struct pingu_host *host)
{
if (host->burst.pings_replied >= host->required_replies) {
pingu_host_set_status(host, 1);
} else if (host->burst.pings_sent >= host->max_retries) {
pingu_host_set_status(host, 0);
} else
pingu_ping_send(loop, host);
return 0;
}
int pingu_host_init(struct ev_loop *loop, struct list_head *host_list)
{
struct pingu_host *host;
list_for_each_entry(host, host_list, host_list_entry) {
ev_timer_init(&host->burst_timeout_watcher,
pingu_burst_timeout_cb, 0, host->burst_interval);
ev_timer_start(loop, &host->burst_timeout_watcher);
}
return 0;
}
|
