Initial commit of version 0.5.1v0.5.1release/v0.5.1

1 files changed, 204 insertions, 0 deletions

diff --git a/txtrecv.h b/txtrecv.h
new file mode 100644
index 0000000..cafb1dd
--- /dev/null
+++ b/txtrecv.h
@@ -0,0 +1,204 @@
+/***************************************************************************
+ *       Copyright (c) 2003,2004 by Marcel Wiesweg                         *
+ *                                                                         *
+ *   This program is free software; you can redistribute it and/or modify  *
+ *   it under the terms of the GNU General Public License as published by  *
+ *   the Free Software Foundation; either version 2 of the License, or     *
+ *   (at your option) any later version.                                   *
+ *                                                                         *
+ ***************************************************************************/
+
+#ifndef __TXTRECV_H                   
+#define __TXTRECV_H
+
+#include <vdr/status.h>
+#include <vdr/receiver.h>
+#include <vdr/thread.h>
+#include <vdr/ringbuffer.h>
+
+#include <stdio.h>
+#include <unistd.h>
+
+struct PageID {
+   PageID() { page=subPage=0; }
+   PageID(tChannelID id, int p, int s) { set(id, p, s); }
+   void set(tChannelID id, int p, int s)
+      { channel=id; page=p; subPage=s; }
+   tChannelID channel;
+   int page;
+   int subPage;
+};
+
+struct StorageHandle {
+public:
+   StorageHandle() { handle=-1; }
+   StorageHandle(const StorageHandle &s) { handle=s.handle; }
+   StorageHandle(int h) { handle=h; }
+   StorageHandle &operator=(int h) { handle=h; return *this; }
+   StorageHandle &operator=(const StorageHandle &s) { handle=s.handle; return *this; }
+   operator bool() const { return handle!=-1; }
+   operator int() const { return handle; }
+private:
+   int handle;
+};
+
+class RootDir {
+public:
+   static void setRootDir(const char *);
+   static const char *getRootDir();
+protected:
+   static const char *root;
+};
+
+class Storage : public RootDir {
+public:
+   virtual ~Storage();
+   enum StorageSystem { StorageSystemLegacy, StorageSystemPacked };
+   //must be called before the first call to instance()
+   static void setSystem(StorageSystem system);
+   void setMaxStorage(int maxMB=-1);
+   
+   static Storage *instance();
+   
+   //must be called before operation starts. Set all options (RootDir, maxStorage) before.
+   void init();   
+   virtual void cleanUp() = 0;
+   
+   virtual void getFilename(char *buffer, int bufLength, PageID page);
+   void prepareDirectory(tChannelID chan);
+   
+   virtual StorageHandle openForWriting(PageID page) = 0;
+   virtual StorageHandle openForReading(PageID page, bool countAsAccess) = 0;
+   virtual ssize_t write(const void *ptr, size_t size, StorageHandle stream) = 0;
+   virtual ssize_t read(void *ptr, size_t size, StorageHandle stream) = 0;
+   virtual void close(StorageHandle stream) = 0;
+protected:
+   virtual void initMaxStorage(int maxMB=-1) = 0;
+   
+   Storage();
+   int cleanSubDir(const char *dir);
+   int doCleanUp();
+   virtual int actualFileSize(int netFileSize) { return netFileSize; }
+   static Storage *s_self;
+   void freeSpace();
+   bool exists(const char* file);
+   
+   long byteCount;
+   char *currentDir;
+private:
+   static StorageSystem system;
+   int storageOption;
+   bool failedFreeSpace;
+};
+
+class LegacyStorage : public Storage {
+public:
+   LegacyStorage();
+   virtual ~LegacyStorage();
+   virtual void cleanUp();
+   
+   virtual StorageHandle openForWriting(PageID page);
+   virtual StorageHandle openForReading(PageID page, bool countAsAccess);
+   virtual ssize_t write(const void *ptr, size_t size, StorageHandle stream);
+   virtual ssize_t read(void *ptr, size_t size, StorageHandle stream)
+     { return ::read((int)stream, ptr, size); }
+   virtual void close(StorageHandle stream)
+     { ::close((int)stream); }
+protected:
+   virtual void initMaxStorage(int maxMB=-1);
+   void registerFile(PageID page);
+   virtual int actualFileSize(int netFileSize);
+   //int maxPages;
+   long maxBytes;
+   int fsBlockSize;
+   int pageBytes;
+};
+
+class PackedStorage : public LegacyStorage {
+public:
+   PackedStorage();
+   //virtual void setMaxStorage(int maxMB=-1);
+   //virtual void cleanUp();
+   
+   virtual void getFilename(char *buffer, int bufLength, PageID page);
+   virtual StorageHandle openForWriting(PageID page);
+   virtual StorageHandle openForReading(PageID page, bool countAsAccess);
+protected:
+   struct PageAddress {
+      bool operator==(const PageID &id) const
+        { return page==id.page && subPage==id.subPage; }
+      void operator=(const PageID &id)
+        { page=id.page; subPage=id.subPage; }
+      int page;
+      int subPage;
+   };
+   bool seekTo(PageID page, int fd, bool create);
+   void registerFile(PageID page);
+};
+
+class cTelePage {
+ private:
+  int mag;
+  unsigned char flags;
+  unsigned char lang;
+  PageID page;
+  unsigned char pagebuf[27*40];
+  char Directory [255];
+ public:
+  cTelePage(PageID page, uchar flags, uchar lang, int mag);
+  ~cTelePage();
+  void SetLine(int, uchar*);
+  void save();
+ };
+
+class cRingTxtFrames : public cRingBufferFrame {
+ public:
+  cRingTxtFrames(int Size) : cRingBufferFrame(Size, true) {};
+  ~cRingTxtFrames() { Clear(); };
+  void Wait(void) { WaitForGet(); };
+  void Signal(void) { EnableGet(); };
+  bool Check(int Size) { return (Free() >= Size); };
+};
+
+class cTxtReceiver : public cReceiver, public cThread {
+private:
+   void DecodeTXT(uchar*);
+   uchar unham16 (uchar*);
+   tChannelID chan;
+   cTelePage *TxtPage;
+protected:
+   virtual void Activate(bool On);
+   virtual void Receive(uchar *Data, int Length);
+   void Action();
+   cRingTxtFrames buffer;
+   bool running;
+public:
+   cTxtReceiver(int TPid, tChannelID chan);
+   virtual ~cTxtReceiver();
+};
+
+class cTxtStatus : public cStatus/*, public cThread*/ {
+private:
+   cTxtReceiver *receiver;
+   //bool running;
+   //cCondVar condVar;
+   //cMutex mutex;
+   //int count;
+protected:
+   int TPid;
+   tChannelID chan;
+   //bool doNotSuspend;
+   //bool doNotReceive; 
+   virtual void ChannelSwitch(const cDevice *Device, int ChannelNumber);
+   //virtual void Action();
+   void CheckCreateReceiver();
+   void CheckDeleteReceiver();
+public:
+   cTxtStatus(void);
+   ~cTxtStatus();
+   //void ForceReceiving(bool onOrOff);
+   //void ForceSuspending(bool onOrOff);
+};
+
+
+#endif