gw-prioqueue.h File Reference

Go to the source code of this file.

Macros
#define	gw_prioqueue_produce(queue, item)   gw_prioqueue_insert(queue, item)

Typedefs
typedef struct gw_prioqueue	gw_prioqueue_t

Functions
gw_prioqueue_t *	gw_prioqueue_create (int(*cmp)(const void *, const void *))
void	gw_prioqueue_destroy (gw_prioqueue_t *queue, void(*item_destroy)(void *))
long	gw_prioqueue_len (gw_prioqueue_t *queue)
void	gw_prioqueue_insert (gw_prioqueue_t *queue, void *item)
void	gw_prioqueue_foreach (gw_prioqueue_t *queue, void(*fn)(const void *, long))
void *	gw_prioqueue_remove (gw_prioqueue_t *queue)
void *	gw_prioqueue_get (gw_prioqueue_t *queue)
void *	gw_prioqueue_consume (gw_prioqueue_t *queue)
void	gw_prioqueue_add_producer (gw_prioqueue_t *queue)
void	gw_prioqueue_remove_producer (gw_prioqueue_t *queue)
long	gw_prioqueue_producer_count (gw_prioqueue_t *queue)

Macro Definition Documentation

gw_prioqueue_produce

#define gw_prioqueue_produce	(		queue,
			item
	)		gw_prioqueue_insert(queue, item)

Definition at line 98 of file gw-prioqueue.h.

Referenced by add_msg_cb(), at2_add_msg_cb(), clear_sent(), emi2_idleprocessing(), and send_msg_cb().

Typedef Documentation

gw_prioqueue_t

typedef struct gw_prioqueue gw_prioqueue_t

Definition at line 68 of file gw-prioqueue.h.

Function Documentation

gw_prioqueue_add_producer()

void gw_prioqueue_add_producer

(

gw_prioqueue_t *

queue

)

Add producer to the priority queue - priority queue

Definition at line 331 of file gw-prioqueue.c.

References gw_assert(), queue, queue_lock(), and queue_unlock().

Referenced by smpp_create().

{
    gw_assert(queue != NULL);

    queue_lock(queue);
    queue->producers++;
    queue_unlock(queue);
}

gw_prioqueue_consume()

void* gw_prioqueue_consume

(

gw_prioqueue_t *

queue

)

Remove biggest item from the priority queue, but block if producers available and none items in the queue - priority queue

Returns

biggest item or NULL if none items and none producers in the queue

Definition at line 303 of file gw-prioqueue.c.

References downheap(), gw_assert(), gwthread_self(), List::len, List::nonempty, queue, queue_lock(), queue_unlock(), and List::tab.

{
    void *ret;
    
    gw_assert(queue != NULL);

    queue_lock(queue);
    while (queue->len == 1 && queue->producers > 0) {
        queue->mutex->owner = -1;
        pthread_cleanup_push((void(*)(void*))pthread_mutex_unlock, &queue->mutex->mutex);
        pthread_cond_wait(&queue->nonempty, &queue->mutex->mutex);
        pthread_cleanup_pop(0);
        queue->mutex->owner = gwthread_self();
    }
    if (queue->len > 1) {
        ret = queue->tab[1]->item;
        gw_free(queue->tab[1]);
        queue->tab[1] = queue->tab[--queue->len];
        downheap(queue, 1);
    } else {
        ret = NULL;
    }
    queue_unlock(queue);
    
    return ret;
}

gw_prioqueue_create()

gw_prioqueue_t* gw_prioqueue_create

(

int(*)(const void *, const void *)

cmp

)

Create priority queue - compare function

Returns

newly created priority queue

Definition at line 174 of file gw-prioqueue.c.

References gw_prioqueue::cmp, gw_assert(), element::item, gw_prioqueue::len, make_bigger(), gw_prioqueue::mutex, mutex_create, gw_prioqueue::nonempty, gw_prioqueue::producers, element::seq, gw_prioqueue::seq, gw_prioqueue::size, and gw_prioqueue::tab.

Referenced by main(), smpp_create(), smsc_at2_create(), and smsc_emi2_create().

{
    gw_prioqueue_t *ret;
     
    gw_assert(cmp != NULL);
    
    ret = gw_malloc(sizeof(*ret));
    ret->producers = 0;
    pthread_cond_init(&ret->nonempty, NULL);
    ret->mutex = mutex_create();
    ret->tab = NULL;
    ret->size = 0;
    ret->len = 0;
    ret->seq = 0;
    ret->cmp = cmp;
    
    /* put NULL item at pos 0 that is our stop marker */
    make_bigger(ret, 1);
    ret->tab[0] = gw_malloc(sizeof(**ret->tab));
    ret->tab[0]->item = NULL;
    ret->tab[0]->seq = ret->seq++;
    ret->len++;
    
    return ret;
}

gw_prioqueue_destroy()

void gw_prioqueue_destroy	(	gw_prioqueue_t *	queue,
		void(*)(void *)	item_destroy
	)

Destroy priority queue - queue to destroy - item destructor

Definition at line 201 of file gw-prioqueue.c.

References item_destroy(), List::len, mutex_destroy(), List::nonempty, queue, and List::tab.

Referenced by at2_device_thread(), emi2_sender(), smpp_destroy(), smsc_at2_create(), and smsc_emi2_create().

{
    long i;

    if (queue == NULL)
        return;
    
    for (i = 0; i < queue->len; i++) {
        if (item_destroy != NULL && queue->tab[i]->item != NULL)
            item_destroy(queue->tab[i]->item);
        gw_free(queue->tab[i]);
    }
    mutex_destroy(queue->mutex);
    pthread_cond_destroy(&queue->nonempty);
    gw_free(queue->tab);
    gw_free(queue);
}

gw_prioqueue_foreach()

void gw_prioqueue_foreach	(	gw_prioqueue_t *	queue,
		void(*)(const void *, long)	fn
	)

Definition at line 252 of file gw-prioqueue.c.

References gw_assert(), List::len, queue, queue_lock(), queue_unlock(), and List::tab.

Referenced by main().

{
    register long i;

    gw_assert(queue != NULL && fn != NULL);
    
    queue_lock(queue);
    for (i = 1; i < queue->len; i++)
        fn(queue->tab[i]->item, i - 1);
    queue_unlock(queue);
}

gw_prioqueue_get()

void* gw_prioqueue_get

(

gw_prioqueue_t *

queue

)

Definition at line 286 of file gw-prioqueue.c.

References gw_assert(), List::len, queue, queue_lock(), queue_unlock(), and List::tab.

{
    void *ret;
    
    gw_assert(queue != NULL);
    
    queue_lock(queue);
    if (queue->len > 1)
        ret = queue->tab[1]->item;
    else
        ret = NULL;
    queue_unlock(queue);
    
    return ret;
}

gw_prioqueue_insert()

void gw_prioqueue_insert	(	gw_prioqueue_t *	queue,
		void *	item
	)

Insert item into the priority queue - priority queue - to be inserted item

Definition at line 235 of file gw-prioqueue.c.

References gw_assert(), element::item, List::len, make_bigger(), List::nonempty, queue, queue_lock(), queue_unlock(), List::tab, and upheap().

Referenced by main().

{
    gw_assert(queue != NULL);
    gw_assert(item != NULL);
    
    queue_lock(queue);
    make_bigger(queue, 1);
    queue->tab[queue->len] = gw_malloc(sizeof(**queue->tab));
    queue->tab[queue->len]->item = item;
    queue->tab[queue->len]->seq = queue->seq++;
    upheap(queue, queue->len);
    queue->len++;
    pthread_cond_signal(&queue->nonempty);
    queue_unlock(queue);
}

gw_prioqueue_len()

long gw_prioqueue_len

(

gw_prioqueue_t *

queue

)

Return priority queue length - priority queue

Returns

length of this priority queue

Definition at line 220 of file gw-prioqueue.c.

References List::len, queue, queue_lock(), and queue_unlock().

Referenced by at2_device_thread(), at2_queued_cb(), at2_send_messages(), emi2_wait(), io_thread(), main(), and queued_cb().

{
    long len;

    if (queue == NULL)
        return 0;
     
    queue_lock(queue);
    len = queue->len - 1;
    queue_unlock(queue);
    
    return len;
}

gw_prioqueue_producer_count()

long gw_prioqueue_producer_count

(

gw_prioqueue_t *

queue

)

Return producer count for the priority queue - priority queue

Returns

producer count

Definition at line 353 of file gw-prioqueue.c.

References gw_assert(), queue, queue_lock(), and queue_unlock().

{
    long ret;

    gw_assert(queue != NULL);
    
    queue_lock(queue);
    ret = queue->producers;
    queue_unlock(queue);
    
    return ret;
}

gw_prioqueue_remove()

void* gw_prioqueue_remove

(

gw_prioqueue_t *

queue

)

Remove biggest item from the priority queue, but not block if producers available and none items in the queue - priority queue

Returns

- biggest item or NULL if none items in the queue

Definition at line 265 of file gw-prioqueue.c.

References downheap(), gw_assert(), List::len, queue, queue_lock(), queue_unlock(), and List::tab.

Referenced by at2_send_messages(), at2_shutdown_cb(), emi2_do_send(), emi2_sender(), io_thread(), main(), open_send_connection(), send_messages(), and shutdown_cb().

{
    void *ret;
    
    gw_assert(queue != NULL);
    
    queue_lock(queue);
    if (queue->len <= 1) {
        queue_unlock(queue);
        return NULL;
    }
    ret = queue->tab[1]->item;
    gw_free(queue->tab[1]);
    queue->tab[1] = queue->tab[--queue->len];
    downheap(queue, 1);
    queue_unlock(queue);
    
    return ret;
}

gw_prioqueue_remove_producer()

void gw_prioqueue_remove_producer

(

gw_prioqueue_t *

queue

)

Remove producer from the priority queue - priority queue

Definition at line 341 of file gw-prioqueue.c.

References gw_assert(), List::nonempty, queue, queue_lock(), and queue_unlock().

{
    gw_assert(queue != NULL);

    queue_lock(queue);
    gw_assert(queue->producers > 0);
    queue->producers--;
    pthread_cond_broadcast(&queue->nonempty);
    queue_unlock(queue);
}