PeerStreamer

	}

		//TODO make timeout at least a DEFINE

		struct timeval timeout = { 4, 0 };

		recvdatabuf[recv_id]->status = INACTIVE;

			arg, &timeout);

		return;

	}

		// Monitoring layer hook

		if(get_Recv_data_inf_cb != NULL) {

			mon_data_inf recv_data_inf;

		*/

		recvdatabuf[recv_id]->timeout_value.tv_sec = recv_timeout.tv_sec;

		recvdatabuf[recv_id]->timeout_value.tv_usec = recv_timeout.tv_usec;

		recvdatabuf[recv_id]->recvID = recv_id;

		recvdatabuf[recv_id]->starttime = time(NULL);

		recvdatabuf[recv_id]->msgtype = msg_h->msg_type;

			}

			//clean up

			free(recvdatabuf[recv_id]->recvbuf);

			free(recvdatabuf[recv_id]);

			recvdatabuf[recv_id] = NULL;

		} else { // not COMPLETE

		}

	}

}