X-Git-Url: http://code.vuplus.com/gitweb/?p=vuplus_dvbapp;a=blobdiff_plain;f=lib%2Fbase%2Ffilepush.cpp;h=eb80914e31ef7c6d0c903cb2e253d010ce90c6aa;hp=af5a8bb68c48e896b2d3039495f52daee378797b;hb=9d9d69d8242d27915c95cb794bd4e7a93759b6db;hpb=875ad71cf9bcace9336cb8eafa8974b84a5347b2

diff --git a/lib/base/filepush.cpp b/lib/base/filepush.cpp
index af5a8bb..eb80914 100644
--- a/lib/base/filepush.cpp
+++ b/lib/base/filepush.cpp
@@ -106,7 +106,7 @@ void eFilePushThread::thread()
 //			eDebug("wrote %d bytes", w);
 			if (w <= 0)
 			{
-				if (errno == EINTR || errno == EAGAIN || errno == EBUSY)
+				if (w < 0 && (errno == EINTR || errno == EAGAIN || errno == EBUSY))
 					continue;
 				eDebug("eFilePushThread WRITE ERROR");
 				sendEvent(evtWriteError);
@@ -227,7 +227,7 @@ void eFilePushThread::thread()
 void eFilePushThread::start(int fd, int fd_dest)
 {
 	eRawFile *f = new eRawFile();
-	ePtr<iDataSource> source = f;
+	ePtr<iTsSource> source = f;
 	f->setfd(fd);
 	start(source, fd_dest);
 }
@@ -235,14 +235,14 @@ void eFilePushThread::start(int fd, int fd_dest)
 int eFilePushThread::start(const char *file, int fd_dest)
 {
 	eRawFile *f = new eRawFile();
-	ePtr<iDataSource> source = f;
+	ePtr<iTsSource> source = f;
 	if (f->open(file) < 0)
 		return -1;
 	start(source, fd_dest);
 	return 0;
 }
 
-void eFilePushThread::start(ePtr<iDataSource> &source, int fd_dest)
+void eFilePushThread::start(ePtr<iTsSource> &source, int fd_dest)
 {
 	m_source = source;
 	m_fd_dest = fd_dest;