asyncqueue.c File Reference

Asynchronous queue. More...

#include <stdlib.h>
#include <stdio.h>
#include <sys/time.h>
#include <assert.h>
#include <err.h>
#include "asyncqueue.h"

Go to the source code of this file.

Macros
#define	PTHREAD_CRITICAL_CALL(fn, ...)
#define	PTHREAD_CALL(fn, ...)

Functions
AsyncQueue *	async_queue_new (CompareFunc compare, FreeFunc free, Pool *pool)
void	async_queue_init (AsyncQueue *queue, CompareFunc compare, FreeFunc free, Pool *pool)
void	async_queue_destroy (AsyncQueue *queue)
void	async_queue_free (AsyncQueue *queue)
void	async_queue_push (AsyncQueue *queue, void *data)
bool	async_queue_pop (AsyncQueue *queue, void *data)
bool	async_queue_pop_timeout (AsyncQueue *queue, void *data, uint32_t ms)
void	async_queue_clear (AsyncQueue *queue)
size_t	async_queue_count (AsyncQueue *queue)

Detailed Description

Asynchronous queue.

Author

Sebastian Fedrau sebas.nosp@m.tian.nosp@m..fedr.nosp@m.au@g.nosp@m.mail..nosp@m.com

Definition in file asyncqueue.c.

Macro Definition Documentation

PTHREAD_CALL

#define PTHREAD_CALL	(		fn,
			...
	)

Value:

{ \
    int rc = fn(__VA_ARGS__); \
    if (rc) \
    { \
        err(rc, "%s()", #fn); \
    } \
}

Definition at line 82 of file asyncqueue.c.

PTHREAD_CRITICAL_CALL

#define PTHREAD_CRITICAL_CALL	(		fn,
			...
	)

Value:

{ \
    int rc = fn(__VA_ARGS__); \
    if (rc) \
    { \
        err(rc, "%s()", #fn); \
        abort(); \
    } \
}

Definition at line 50 of file asyncqueue.c.

Function Documentation

async_queue_clear()

void async_queue_clear

(

AsyncQueue *

queue

)

Parameters

queue

an AsyncQueue

Clears a queue.

Definition at line 205 of file asyncqueue.c.

async_queue_count()

size_t async_queue_count

(

AsyncQueue *

queue

)

Parameters

queue

an AsyncQueue

Returns

number of items

Gets the number of stored items.

Definition at line 217 of file asyncqueue.c.

async_queue_destroy()

void async_queue_destroy

(

AsyncQueue *

queue

)

Parameters

queue

an AsyncQueue

Frees all items and the queue pointer.

Definition at line 74 of file asyncqueue.c.

async_queue_free()

void async_queue_free

(

AsyncQueue *

queue

)

Parameters

queue

an AsyncQueue

Frees all items without freeing the queue pointer.

Definition at line 92 of file asyncqueue.c.

async_queue_init()

void async_queue_init	(	AsyncQueue *	queue,
		CompareFunc	compare,
		FreeFunc	free,
		Pool *	pool
	)

Parameters

queue	an AsyncQueue
compare	function to compare item data
free	function to free item data or NULL
pool	a user-defined memory pool for creating/destroying QueueItems or NULL

Initializes an AsyncQueue.

Definition at line 61 of file asyncqueue.c.

async_queue_new()

AsyncQueue * async_queue_new	(	CompareFunc	compare,
		FreeFunc	free,
		Pool *	pool
	)

Parameters

compare	function to compare item data
free	function to free item data or NULL
pool	a user-defined memory pool for creating/destroying QueueItems or NULL

Returns

a new AsyncQueue

Creates a new AsyncQueue.

Definition at line 33 of file asyncqueue.c.

async_queue_pop()

bool async_queue_pop	(	AsyncQueue *	queue,
		void *	data
	)

Parameters

queue	an AsyncQueue
data	location to store data of removed element

Returns

true on success

Pops data from the queue.

Definition at line 191 of file asyncqueue.c.

async_queue_pop_timeout()

bool async_queue_pop_timeout	(	AsyncQueue *	queue,
		void *	data,
		uint32_t	ms
	)

Parameters

queue	an AsyncQueue
data	location to store data of removed element
ms	timeout in milliseconds

Returns

true on success

Pops data from the queue. Blocks for ms milliseconds.

Definition at line 199 of file asyncqueue.c.

async_queue_push()

void async_queue_push	(	AsyncQueue *	queue,
		void *	data
	)

Parameters

queue	an AsyncQueue
data	data to push

Pushs data onto the queue.

Definition at line 103 of file asyncqueue.c.