FFNetDev-Plugin

git-svn-id: svn://svn.berlios.de/ffnetdev/trunk@1 1f4bef6d-8e0a-0410-8695-e467da8aaccf

1 files changed, 166 insertions, 0 deletions

diff --git a/streamdevice.c b/streamdevice.c
new file mode 100644
index 0000000..9c9aef1
--- /dev/null
+++ b/streamdevice.c
@@ -0,0 +1,166 @@
+/* 
+ * streamdevice.c: streaming network device
+ *
+ * See the README file for copyright information and how to reach the author.
+ *
+ */
+ 
+#include "streamdevice.h"
+#include "osdworker.h"
+#include "tsworker.h"
+#include "netosd.h"
+
+cStreamDevice::cStreamDevice(void)
+{
+#ifdef DEBUG
+    fprintf(stderr,"[ffnetdev] Device: Constructor cStreamDevice \n");
+#endif
+    m_Remux = new cPES2TSRemux(TS_VPID, TS_APID);   
+
+}
+
+cStreamDevice::~cStreamDevice(void)
+{
+#ifdef DEBUG    
+    fprintf(stderr,"[ffnetdev] Device: Destructor cStreamDevice \n");
+#endif
+    DELETENULL(m_Remux);
+}
+
+
+void cStreamDevice::MakePrimaryDevice(bool On)
+{
+#ifdef DEBUG
+  fprintf(stderr,"[ffnetdev] Device: ffnetdev becomes primary device. Registering our OSD provider...\n");
+#endif
+  new cNetOSDProvider();
+}
+
+int cStreamDevice::ProvidesCa(const cChannel *Channel) const
+{
+    return 0;
+}
+
+bool cStreamDevice::HasDecoder(void) const
+{
+    return true; // We can decode MPEG2
+}
+
+bool cStreamDevice::CanReplay(void) const
+{
+    return true;  // We can replay
+}
+
+bool cStreamDevice::SetPlayMode(ePlayMode PlayMode)
+{
+    fprintf(stderr, "[ffnetdev] Device: Setting playmode(not implemented). Mode: %d\n",PlayMode);
+    cOSDWorker::SendPlayMode(PlayMode);
+    m_Remux->ClearInput();
+    m_Remux->ClearOutput();
+    m_Remux->PlayModeChange();
+    return true;
+}
+
+void cStreamDevice::TrickSpeed(int Speed)
+{
+    fprintf(stderr,"[ffnetdev] Device: Trickspeed(not implemented). Speed: %d\n", Speed);
+    m_Remux->ClearInput();
+    m_Remux->ClearOutput();
+    m_Remux->PlayModeChange();
+}
+
+void cStreamDevice::Clear(void)
+{
+    fprintf(stderr,"[ffnetdev] Device: Clear(not implemented).\n");
+    m_Remux->ClearInput();
+    m_Remux->ClearOutput();
+    m_Remux->PlayModeChange();
+//    cDevice::Clear();
+}
+void cStreamDevice::Play(void)
+{
+    fprintf(stderr,"[ffnetdev] Device: Play(not implemented).\n");
+//    cDevice::Play();
+}
+
+void cStreamDevice::Freeze(void)
+{
+    fprintf(stderr,"[ffnetdev] Device: Freeze(not implemented).\n");
+//    cDevice::Freeze();
+}
+
+void cStreamDevice::Mute(void)
+{
+    fprintf(stderr,"[ffnetdev] Device: Mute(not implemented).\n");
+//    cDevice::Mute();
+}
+
+void cStreamDevice::SetVolumeDevice(int Volume)
+{
+  fprintf (stderr, "[ffnetdev] Device: Setting volume to %d (not implemented).\n", Volume);
+}
+
+void cStreamDevice::StillPicture(const uchar *Data, int Length)
+{
+    fprintf(stderr,"[ffnetdev] Device: StillPicture(not implemented).\n");
+}
+
+bool cStreamDevice::Poll(cPoller &Poller, int TimeoutMs)
+{
+  //fprintf(stderr,"[ffnetdev] Device: Poll TimeoutMs: %d ....\n",TimeoutMs);
+  return true;
+}
+/* ----------------------------------------------------------------------------
+ */
+int cStreamDevice::PlayAudio(const uchar *Data, int Length)
+{
+   if (cTSWorker::HaveStreamClient()) {
+       while ((m_Remux->Free() < Length) && cTSWorker::HaveStreamClient())
+           cCondWait::SleepMs(1);
+       int result=m_Remux->Put(Data, Length);
+       if (result!=Length) {
+         fprintf(stderr,"[ffnetdev] Device: Did not put all in input buffer(audio). result:%d Length: %d Skipping Audio PES packet...\n", result, Length );
+         // Delete part of data already written to buffer 
+         m_Remux->DelInput(result);
+         return (0);
+        }
+        else
+	{
+            return ( Length );
+	}
+   }
+   else
+   {
+      m_Remux->ClearInput();
+      usleep(100000);
+      return ( 0 );
+   }
+  
+}
+
+/* ----------------------------------------------------------------------------
+ */
+int cStreamDevice::PlayVideo(const uchar *Data, int Length)
+{
+   if (cTSWorker::HaveStreamClient()) {
+       while ((m_Remux->Free() < Length) && cTSWorker::HaveStreamClient())
+           cCondWait::SleepMs(1);
+       int result=m_Remux->Put(Data, Length);
+       if (result!=Length) {
+         fprintf(stderr,"[ffnetdev] Device: Did not put all in input buffer(video). result:%d Length: %d Skipping Video PES packet...\n", result, Length );
+         // Delete part of data already written to buffer 
+         m_Remux->DelInput(result);
+         return (0);
+       }
+       else
+       {
+           return ( Length );
+       }
+   }
+   else
+   {
+      m_Remux->ClearInput();
+      usleep(100000);
+      return ( 0 );
+   }
+}