From de0f72b065f83042e6933b63487eb8124e643990 Mon Sep 17 00:00:00 2001
From: Felix Domke <tmbinc@elitedvb.net>
Date: Sun, 13 Nov 2005 18:25:04 +0000
Subject: [PATCH] add flush to filepush

---
 lib/base/filepush.cpp | 8 +++++++-
 lib/base/filepush.h   | 3 +++
 2 files changed, 10 insertions(+), 1 deletion(-)

diff --git a/lib/base/filepush.cpp b/lib/base/filepush.cpp
index ee83f142..73dc5190 100644
--- a/lib/base/filepush.cpp
+++ b/lib/base/filepush.cpp
@@ -7,7 +7,7 @@
 eFilePushThread::eFilePushThread()
 {
 	m_stop = 0;
-	m_buf_start = m_buf_end = 0;
+	flush();
 }
 
 static void signal_handler(int x)
@@ -108,3 +108,9 @@ void eFilePushThread::resume()
 	m_stop = 0;
 	run();
 }
+
+void eFilePushThread::flush()
+{
+	m_buf_start = m_buf_end = 0;
+}
+
diff --git a/lib/base/filepush.h b/lib/base/filepush.h
index 021a7c94..a419d719 100644
--- a/lib/base/filepush.h
+++ b/lib/base/filepush.h
@@ -16,6 +16,9 @@ public:
 	void seek(int whence, off_t where);
 	void resume();
 	
+		/* flushes the internal readbuffer */ 
+	void flush();
+	
 private:
 	int m_stop;
 	unsigned char m_buffer[65536];
-- 
2.30.2