#include <stdio.h>
#include <stdlib.h>
#include <pthread.h>
#include <unistd.h>

/* Non standard include */
#include <common_comm.h>
#include <specific_comm.h>


struct communication_assoc *create_comm_assoc(void)
{
	struct communication_assoc *assoc;

	assoc = (struct communication_assoc *) malloc(sizeof(struct communication_assoc));
	assoc->tid = pthread_self();
	return assoc;
}

void reception(void (*on_receive)(void *))
{
	wait_initialization();
	/* printf("Activate the consumer...\n"); */
	while (cont);
}