git.cweiske.de
/
enigma2.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
add stream-mode to filepush, which will retry on eof until stream grows
[enigma2.git]
/
lib
/
base
/
filepush.cpp
diff --git
a/lib/base/filepush.cpp
b/lib/base/filepush.cpp
index 8424ae4197fd219469d3702b2c7be4f68e60b89f..92c580c22d43c22cb6c05ce2915b507ce6a8cc69 100644
(file)
--- a/
lib/base/filepush.cpp
+++ b/
lib/base/filepush.cpp
@@
-11,6
+11,8
@@
eFilePushThread::eFilePushThread(int io_prio_class, int io_prio_level)
{
m_stop = 0;
m_sg = 0;
{
m_stop = 0;
m_sg = 0;
+ m_send_pvr_commit = 0;
+ m_stream_mode = 0;
flush();
enablePVRCommit(0);
CONNECT(m_messagepump.recv_msg, eFilePushThread::recvEvent);
flush();
enablePVRCommit(0);
CONNECT(m_messagepump.recv_msg, eFilePushThread::recvEvent);
@@
-128,7
+130,19
@@
void eFilePushThread::thread()
/* well check again */
continue;
}
/* well check again */
continue;
}
+
+ /* in stream_mode, we are sending EOF events
+ over and over until somebody responds.
+
+ in stream_mode, think of evtEOF as "buffer underrun occured". */
sendEvent(evtEOF);
sendEvent(evtEOF);
+
+ if (m_stream_mode)
+ {
+ eDebug("reached EOF, but we are in stream mode. delaying 1 second.");
+ sleep(1);
+ continue;
+ }
#if 0
eDebug("FILEPUSH: end-of-file! (currently unhandled)");
if (!m_raw_source.lseek(0, SEEK_SET))
#if 0
eDebug("FILEPUSH: end-of-file! (currently unhandled)");
if (!m_raw_source.lseek(0, SEEK_SET))
@@
-214,6
+228,11
@@
void eFilePushThread::enablePVRCommit(int s)
m_send_pvr_commit = s;
}
m_send_pvr_commit = s;
}
+void eFilePushThread::setStreamMode(int s)
+{
+ m_stream_mode = s;
+}
+
void eFilePushThread::setScatterGather(iFilePushScatterGather *sg)
{
m_sg = sg;
void eFilePushThread::setScatterGather(iFilePushScatterGather *sg)
{
m_sg = sg;