42 i = pthread_mutex_init(&queue->
mutex, NULL);
47 if (!(queue->
first)) {
54 newelem = malloc(
sizeof(
qelem_t));
57 while(queue->
first!=NULL) {
60 queue->
first = current;
64 memset(newelem, 0,
sizeof(
qelem_t));
80 current = queue->
first;
82 if (current != NULL) {
85 queue->
first = current;
92 pthread_mutex_destroy(&queue->
mutex);
107 pthread_mutex_lock(&queue->
mutex);
111 pthread_mutex_unlock(&queue->
mutex);
127 pthread_mutex_lock(&queue->
mutex);
132 pthread_mutex_unlock(&queue->
mutex);
145 pthread_mutex_lock(&queue->
mutex);
146 qelem = queue->
nelem;
147 pthread_mutex_unlock(&queue->
mutex);
void queue_deinit(queue_t *queue)
int queue_init(queue_t *queue)
int queue(queue_t *queue, void *data)
int getquenelem(queue_t *queue)
void * dequeue(queue_t *queue)
#define MAX_QUEUE_ELEMENTS