1 files changed, 65 insertions, 0 deletions
diff --git a/src/include/multibuffer.h b/src/include/multibuffer.h
new file mode 100644
index 0000000..e0ed05c
--- /dev/null
+++ b/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