PeerStreamer

 * @param arg

 */

static void connReady_cb (int connectionID, void *arg) {

	msgData_cb *p;

	p = (msgData_cb *)arg;

	if (p == NULL) return;

	    return;

	}

	mlSendData(connectionID,(char *)(sendingBuffer[p->bIdx]),p->mSize,p->msgType,NULL);

	if (mt!=MSG_TYPE_TOPOLOGY &&

		mt!=MSG_TYPE_CHUNK && mt!=MSG_TYPE_SIGNALLING) {

			fprintf(stderr,"Net-helper ERROR! Sent message # %d of type %c and size %d\n",

 */

static void recv_data_cb(char *buffer, int buflen, unsigned char msgtype, recv_params *arg) {

// TODO: lacks a void* arg... moreover: recv_params has a msgtype, but there is also a msgtype explicit argument...

//	fprintf(stderr, "Net-helper : called back with some news...\n");

/**/ ++recv_counter;

	if (arg->remote_socketID != NULL)

		mlSocketIDToString(arg->remote_socketID,str,SOCKETID_STRING_SIZE);

	else

struct nodeID *net_helper_init(const char *IPaddr, int port) {

	struct timeval tout = NH_ML_INIT_TIMEOUT;

	base = event_base_new();

	lookup_array = calloc(lookup_max,sizeof(struct nodeID *));

	me->connID = -10;	// dirty trick to spot later if the ml has called back ...

	me->refcnt = 1;

	for (i=0;i<NH_BUFFER_SIZE;i++) {

		sendingBuffer[i] = NULL;

		receivedBuffer[i].data = NULL;

 */

int send_to_peer(const struct nodeID *from, struct nodeID *to, const uint8_t *buffer_ptr, int buffer_size)

{

	// if buffer is full, discard the message and return an error flag

	int index = next_S();

	if (index<0) {

	memset(sendingBuffer[index],0,buffer_size);

	memcpy(sendingBuffer[index],buffer_ptr,buffer_size);

	// free(buffer_ptr);

	p->bIdx = index; p->mSize = buffer_size; p->msgType = (unsigned char)buffer_ptr[0]; p->conn_cb_called = false; p->cancelled = false;

	to->connID = mlOpenConnection(to->addr,&connReady_cb,p, params);

	if (to->connID<0) {

		free_sending_buffer(current);