diff options
| -rw-r--r-- | pingu_host.c | 49 |
1 files changed, 49 insertions, 0 deletions
diff --git a/pingu_host.c b/pingu_host.c new file mode 100644 index 0000000..eda2c94 --- /dev/null +++ b/pingu_host.c @@ -0,0 +1,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; +} + |