summaryrefslogtreecommitdiff
path: root/ringbuffer.c
diff options
context:
space:
mode:
authorKlaus Schmidinger <vdr@tvdr.de>2003-05-12 17:46:34 +0200
committerKlaus Schmidinger <vdr@tvdr.de>2003-05-12 17:46:34 +0200
commit1c1fdc5a3f1096c7b2649a6817102685574671a5 (patch)
treea974c5a02be9606d3e44286f9ea737cd5d538024 /ringbuffer.c
parent2a7472b00a310c11a81a2a29794eba03cba1c1d1 (diff)
downloadvdr-1c1fdc5a3f1096c7b2649a6817102685574671a5.tar.gz
vdr-1c1fdc5a3f1096c7b2649a6817102685574671a5.tar.bz2
Re-implemented the WaitForPut/WaitForGet stuff in cRingBuffer, since some plugins actually need this
Diffstat (limited to 'ringbuffer.c')
-rw-r--r--ringbuffer.c51
1 files changed, 50 insertions, 1 deletions
diff --git a/ringbuffer.c b/ringbuffer.c
index 770b7c34..2cf9d75d 100644
--- a/ringbuffer.c
+++ b/ringbuffer.c
@@ -7,7 +7,7 @@
* Parts of this file were inspired by the 'ringbuffy.c' from the
* LinuxDVB driver (see linuxtv.org).
*
- * $Id: ringbuffer.c 1.16 2003/05/11 09:47:56 kls Exp $
+ * $Id: ringbuffer.c 1.17 2003/05/12 17:38:11 kls Exp $
*/
#include "ringbuffer.h"
@@ -23,6 +23,7 @@ cRingBuffer::cRingBuffer(int Size, bool Statistics)
statistics = Statistics;
maxFill = 0;
lastPercent = 0;
+ putTimeout = getTimeout = 0;
}
cRingBuffer::~cRingBuffer()
@@ -31,6 +32,42 @@ cRingBuffer::~cRingBuffer()
dsyslog("buffer stats: %d (%d%%) used", maxFill, maxFill * 100 / (size - 1));
}
+void cRingBuffer::WaitForPut(void)
+{
+ if (putTimeout) {
+ putMutex.Lock();
+ readyForPut.TimedWait(putMutex, putTimeout);
+ putMutex.Unlock();
+ }
+}
+
+void cRingBuffer::WaitForGet(void)
+{
+ if (getTimeout) {
+ getMutex.Lock();
+ readyForGet.TimedWait(getMutex, getTimeout);
+ getMutex.Unlock();
+ }
+}
+
+void cRingBuffer::EnablePut(void)
+{
+ if (putTimeout)
+ readyForPut.Broadcast();
+}
+
+void cRingBuffer::EnableGet(void)
+{
+ if (getTimeout)
+ readyForGet.Broadcast();
+}
+
+void cRingBuffer::SetTimeouts(int PutTimeout, int GetTimeout)
+{
+ putTimeout = PutTimeout;
+ getTimeout = GetTimeout;
+}
+
// --- cRingBufferLinear -----------------------------------------------------
cRingBufferLinear::cRingBufferLinear(int Size, int Margin, bool Statistics)
@@ -68,6 +105,8 @@ void cRingBufferLinear::Clear(void)
head = tail = margin;
lastGet = -1;
Unlock();
+ EnablePut();
+ EnableGet();
}
int cRingBufferLinear::Put(const uchar *Data, int Count)
@@ -109,6 +148,9 @@ int cRingBufferLinear::Put(const uchar *Data, int Count)
else
Count = 0;
Unlock();
+ EnableGet();
+ if (Count == 0)
+ WaitForPut();
}
return Count;
}
@@ -134,6 +176,8 @@ uchar *cRingBufferLinear::Get(int &Count)
Count = lastGet = cont;
}
Unlock();
+ if (!p)
+ WaitForGet();
return p;
}
@@ -146,6 +190,7 @@ void cRingBufferLinear::Del(int Count)
if (tail >= Size())
tail = margin;
Unlock();
+ EnablePut();
}
else
esyslog("ERROR: invalid Count in cRingBufferLinear::Del: %d", Count);
@@ -196,6 +241,8 @@ void cRingBufferFrame::Clear(void)
while ((p = Get()) != NULL)
Drop(p);
Unlock();
+ EnablePut();
+ EnableGet();
}
bool cRingBufferFrame::Put(cFrame *Frame)
@@ -212,6 +259,7 @@ bool cRingBufferFrame::Put(cFrame *Frame)
}
currentFill += Frame->Count();
Unlock();
+ EnableGet();
return true;
}
return false;
@@ -249,6 +297,7 @@ void cRingBufferFrame::Drop(cFrame *Frame)
esyslog("ERROR: attempt to drop wrong frame from ring buffer!");
}
Unlock();
+ EnablePut();
}
int cRingBufferFrame::Available(void)