move soures to src subdir

1 files changed, 67 insertions, 0 deletions

diff --git a/src/pingu_burst.c b/src/pingu_burst.c
new file mode 100644
index 0000000..3505c94
--- /dev/null
+++ b/src/pingu_burst.c
@@ -0,0 +1,67 @@
+#include <sys/socket.h>
+#include <sys/types.h>
+
+#include <netdb.h>
+#include <string.h>
+
+#include <ev.h>
+
+#include "log.h"
+#include "pingu_burst.h"
+#include "pingu_host.h"
+#include "pingu_ping.h"
+#include "pingu_iface.h"
+
+void ping_burst_start(struct ev_loop *loop, struct pingu_host *host)
+{
+	struct addrinfo hints;
+	struct addrinfo *ai = NULL, *rp;
+	int r;
+	char buf[64];
+
+	/* we bind to device every burst in case an iface disappears and
+	   comes back. e.g ppp0 */
+	if (pingu_iface_bind_socket(host->iface, host->status) < 0) {
+		pingu_host_set_status(host, PINGU_HOST_STATUS_OFFLINE);
+		return;
+	}
+
+	host->burst.active = 1;
+	host->burst.pings_sent = 0;
+	host->burst.pings_replied = 0;
+
+	memset(&hints, 0, sizeof(hints));
+	hints.ai_family = AF_INET;
+	r = getaddrinfo(host->host, NULL, &hints, &ai);
+	if (r < 0) {
+		log_error("getaddrinfo(%s): %s", host->host, gai_strerror(r));
+		return;
+	}
+
+	for (rp = ai; rp != NULL; rp = rp->ai_next) {
+		sockaddr_from_addrinfo(&host->burst.saddr, ai);
+		r = pingu_ping_send(loop, host, PINGU_PING_IGNORE_ERROR);
+		if (r == 0)
+			break;
+	}
+
+	sockaddr_to_string(&host->burst.saddr, buf, sizeof(buf));
+	if (rp == NULL) {
+		log_debug("%s: failed to send first ping to %s", host->label, buf);
+		host->burst.active = 0;
+	}
+	freeaddrinfo(ai);
+}
+
+void pingu_burst_timeout_cb(struct ev_loop *loop, struct ev_timer *w,
+                            int revents)
+{
+	struct pingu_host *host = container_of(w, struct pingu_host, burst_timeout_watcher);
+
+	if (host->burst.active) {
+		log_warning("%s: burst already active", host->host);
+		return;
+	}
+	log_debug("%s: new burst to %s via %s", host->label, host->host, host->iface->name);
+	ping_burst_start(loop, host);
+}