PeerStreamer

#include "msg_types.h"

void keepalive_fn(evutil_socket_t fd, short what, void *arg) {

	socketID_handle peer = arg;

	int con_id = mlConnectionExist(peer, false);

	if (con_id < 0 || connectbuf[con_id]->defaultSendParams.keepalive <= 0) {

		/* Connection fell from under us or keepalive was disabled */

		free(arg);

		return;

	}

	/* do what we gotta do */

	if ( connectbuf[con_id]->status == READY) {

		char keepaliveMsg[32] = "";

		sprintf(keepaliveMsg, "KEEPALIVE %d", connectbuf[con_id]->keepalive_seq++);

		send_msg(con_id, MSG_TYPE_ML_KEEPALIVE, keepaliveMsg, 1 + strlen(keepaliveMsg), false, 

			&(connectbuf[con_id]->defaultSendParams));

	}

	/* re-schedule */

	struct timeval t = { 0,0 };

	t.tv_sec = time(NULL) + connectbuf[con_id]->defaultSendParams.keepalive;

	event_base_once(base, -1, EV_TIMEOUT, keepalive_fn, peer, &t);

}

void setupKeepalive(int conn_id) {

	/* Save the peer's address for us */

	socketID_handle peer = malloc(sizeof(socket_ID));

	memcpy(peer, &connectbuf[conn_id]->external_socketID, sizeof(socket_ID));

	struct timeval t = { 0,0 };

	t.tv_sec = time(NULL) + connectbuf[conn_id]->defaultSendParams.keepalive;

	event_base_once(base, -1, EV_TIMEOUT, keepalive_fn, peer, &t);

}

		bool newKeepalive = 

			connectbuf[con_id]->defaultSendParams.keepalive == 0 && defaultSendParams.keepalive != 0;

		if (newKeepalive) setupKeepalive(con_id);

			if (defaultSendParams.keepalive) setupKeepalive(con_id);