PeerStreamer

static uint8_t *sendingBuffer[NH_BUFFER_SIZE];

// pointers to the received msgs + sender nodeID

static uint8_t *receivedBuffer[NH_BUFFER_SIZE][2];

/**

 * Look for a free slot in the received buffer and allocates it for immediate use

	p = (msgData_cb *)arg;

	if (p == NULL) return;

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

	free(sendingBuffer[p->bIdx]);

	sendingBuffer[p->bIdx] = NULL;

//	fprintf(stderr,"Net-helper: Message # %d for connection %d sent!\n ", p->bIdx,connectionID);

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");

	char str[SOCKETID_STRING_SIZE];

	if (arg->remote_socketID != NULL)

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

		sprintf(str,"!Unknown!");

	if (arg->nrMissingBytes || !arg->firstPacketArrived) {

	    fprintf(stderr, "Net-helper : corrupted message arrived from %s\n",str);

	}

	else {

	//	fprintf(stderr, "Net-helper : message arrived from %s\n",str);