diff options
author | Timothy Pearson <kb9vqf@pearsoncomputing.net> | 2013-02-01 17:25:34 -0600 |
---|---|---|
committer | Timothy Pearson <kb9vqf@pearsoncomputing.net> | 2013-02-01 17:25:34 -0600 |
commit | 48906a623383ab5222541ae048e99dd039b62a9a (patch) | |
tree | 1c5f588e90899bb1301f79cf97b8f6ddc0b1c367 /tderadio3/src/include/multibuffer.h | |
parent | a1e6ce502c334194d31a0b78b11b77e9532da64b (diff) | |
download | tderadio-48906a623383ab5222541ae048e99dd039b62a9a.tar.gz tderadio-48906a623383ab5222541ae048e99dd039b62a9a.zip |
Fix FTBFS
Diffstat (limited to 'tderadio3/src/include/multibuffer.h')
-rw-r--r-- | tderadio3/src/include/multibuffer.h | 65 |
1 files changed, 65 insertions, 0 deletions
diff --git a/tderadio3/src/include/multibuffer.h b/tderadio3/src/include/multibuffer.h new file mode 100644 index 0000000..e0ed05c --- /dev/null +++ b/tderadio3/src/include/multibuffer.h @@ -0,0 +1,65 @@ +/*************************************************************************** + multibuffer.h + ------------------- + begin : Sat Aug 20 2005 + copyright : (C) 2005 by Martin Witte + email : witte@kawo1.rwth-aachen.de + ***************************************************************************/ + +/*************************************************************************** + * * + * This program is free software; you can redistribute it and/or modify * + * it under the terms of the GNU General Public License as published by * + * the Free Software Foundation; either version 2 of the License, or * + * (at your option) any later version. * + * * + ***************************************************************************/ + +#ifndef KRADIO_MULTIBUFFER_H +#define KRADIO_MULTIBUFFER_H + +#ifdef HAVE_CONFIG_H +#include <config.h> +#endif + +#include <tqsemaphore.h> +#include <tqstring.h> + +class MultiBuffer +{ +public: + MultiBuffer(size_t n_buffers, size_t buffersize); + ~MultiBuffer(); + + char *lockWriteBuffer (size_t &bufferSize); + bool unlockWriteBuffer (size_t bufferSize); // return value: complete buffer full / ready for read + void unlockAllWriteBuffers(); + char *wait4ReadBuffer (size_t &buffer_fill); + char *getCurrentReadBuffer(size_t &buffer_fill) const; + + const TQString &getErrorString() const { return m_errorString; } + bool hasError() const { return m_error; } + void resetError(); + + size_t getWriteBufferFill() const { return (m_currentReadBuffer != m_currentWriteBuffer) ? m_buffersFill[m_currentWriteBuffer] : 0; } + size_t getAvailableWriteBuffer() const; + size_t getAvailableReadBuffers() const; + size_t getCurrentReadBufferIdx() const { return m_currentReadBuffer; } + size_t getCurrentWriteBufferIdx() const { return m_currentWriteBuffer; } + +protected: + + size_t m_nBuffers; + size_t m_BufferSize; + + char **m_buffers; + size_t *m_buffersFill; + size_t m_currentReadBuffer; + size_t m_currentWriteBuffer; + TQSemaphore m_readLock; + + TQString m_errorString; + bool m_error; +}; + +#endif |