Mercurial > hg > audiostuff
diff spandsp-0.0.3/spandsp-0.0.3/src/spandsp/queue.h @ 5:f762bf195c4b
import spandsp-0.0.3
author | Peter Meerwald <pmeerw@cosy.sbg.ac.at> |
---|---|
date | Fri, 25 Jun 2010 16:00:21 +0200 |
parents | |
children |
line wrap: on
line diff
--- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/spandsp-0.0.3/spandsp-0.0.3/src/spandsp/queue.h Fri Jun 25 16:00:21 2010 +0200 @@ -0,0 +1,151 @@ +/* + * SpanDSP - a series of DSP components for telephony + * + * queue.h - simple in process message queuing + * + * Written by Steve Underwood <steveu@coppice.org> + * + * Copyright (C) 2004 Steve Underwood + * + * All rights reserved. + * + * This program is free software; you can redistribute it and/or modify + * it under the terms of the GNU General Public License version 2, as + * published by the Free Software Foundation. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with this program; if not, write to the Free Software + * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. + * + * $Id: queue.h,v 1.4 2006/10/24 13:45:28 steveu Exp $ + */ + +/*! \file */ + +/*! \page queue_page Queuing +\section queue_page_sec_1 What does it do? +???. + +\section queue_page_sec_2 How does it work? +???. +*/ + +#if !defined(_QUEUE_H_) +#define _QUEUE_H_ + +#define QUEUE_READ_ATOMIC 0x0001 +#define QUEUE_WRITE_ATOMIC 0x0002 + +typedef struct +{ + int len; + int iptr; + int optr; + int flags; + uint8_t *data; +} queue_t; + +#ifdef __cplusplus +extern "C" { +#endif + +/*! Check if a queue is empty. + \brief Check if a queue is empty. + \param p The queue context. + \return TRUE if empty, else FALSE. */ +int queue_empty(queue_t *p); + +/*! Check the available free space in a queue's buffer. + \brief Check available free space. + \param p The queue context. + \return The number of bytes of free space. */ +int queue_free_space(queue_t *p); + +/*! Check the contents of a queue. + \brief Check the contents of a queue. + \param p The queue context. + \return The number of bytes in the queue. */ +int queue_contents(queue_t *p); + +/*! Flush the contents of a queue. + \brief Flush the contents of a queue. + \param p The queue context. */ +void queue_flush(queue_t *p); + +/*! Copy bytes from a queue. This is similar to queue_read, but + the data remains in the queue. + \brief Copy bytes from a queue. + \param p The queue context. + \param buf The buffer into which the bytes will be read. + \param len The length of the buffer. + \return the number of bytes returned. */ +int queue_view(queue_t *p, uint8_t *buf, int len); + +/*! Read bytes from a queue. + \brief Read bytes from a queue. + \param p The queue context. + \param buf The buffer into which the bytes will be read. + \param len The length of the buffer. + \return the number of bytes returned. */ +int queue_read(queue_t *p, uint8_t *buf, int len); + +/*! Write bytes to a queue. + \brief Write bytes to a queue. + \param p The queue context. + \param buf The buffer containing the bytes to be written. + \param len The length of the buffer. + \return the number of bytes actually written. */ +int queue_write(queue_t *p, const uint8_t *buf, int len); + +/*! Test the length of the message at the head of a queue. + \brief Test message length. + \param p The queue context. + \return The length of the next message, in byte. If there are + no messages in the queue, -1 is returned. */ +int queue_test_msg(queue_t *p); + +/*! Read a message from a queue. If the message is longer than the buffer + provided, only the first len bytes of the message will be returned. The + remainder of the message will be discarded. + \brief Read a message from a queue. + \param p The queue context. + \param buf The buffer into which the message will be read. + \param len The length of the buffer. + \return The number of bytes returned. If there are + no messages in the queue, -1 is returned. */ +int queue_read_msg(queue_t *p, uint8_t *buf, int len); + +/*! Write a message to a queue. + \brief Write a message to a queue. + \param p The queue context. + \param buf The buffer from which the message will be written. + \param len The length of the message. + \return The number of bytes actually written. */ +int queue_write_msg(queue_t *p, const uint8_t *buf, int len); + +/*! Create a queue. + \brief Create a queue. + \param p The queue context. + \param len The length of the queue's buffer. + \param flags Flags controlling the operation of the queue. + Valid flags are QUEUE_READ_ATOMIC and QUEUE_WRITE_ATOMIC. + \return 0 if created OK, else -1. */ +int queue_create(queue_t *p, int len, int flags); + +/*! Delete a queue. + \brief Delete a queue. + \param p The queue context. + \return 0 if deleted OK, else -1. */ +int queue_delete(queue_t *p); + +#ifdef __cplusplus +} +#endif + +#endif +/*- End of file ------------------------------------------------------------*/