include/lib/dvb/dvbci.h

   1 #ifndef __core_dvb_ci_h
   2 #define __core_dvb_ci_h
   3
   4 #include <lib/dvb/service.h>
   5 #include <lib/base/ebase.h>
   6 #include <lib/base/thread.h>
   7 #include <lib/base/message.h>
   8 #include <lib/system/elock.h>
   9 #include <set>
  10 #include <queue>
  11
  12 #define PMT_ENTRYS  256
  13
  14 struct session_struct
  15 {
  16         unsigned int tc_id;
  17         unsigned long service_class;
  18         unsigned int state;
  19         unsigned int internal_state;
  20 };
  21
  22 struct tempPMT_t
  23 {
  24         int type;  // 0 = version 1=pid 2=descriptor
  25         unsigned char *descriptor;
  26         union
  27         {
  28                 unsigned short pid;
  29                 unsigned short version;
  30         };
  31         unsigned short streamtype;
  32 };
  33
  34 #define MAXTRANSPORTSESSIONS 32
  35 #define PCMCIABUFLEN 255
  36 #define LPDUHEADERLEN 2
  37 #define LPDUPAYLOADLEN (PCMCIABUFLEN - LPDUHEADERLEN)
  38
  39 typedef struct _lpduQueueElem lpduQueueElem;
  40 typedef struct _lpduQueueElem * ptrlpduQueueElem;
  41
  42 typedef struct _lpduQueueHeader lpduQueueHeader;
  43
  44 struct queueData
  45 {
  46         __u8 prio;
  47         unsigned char tc_id;
  48         unsigned char *data;
  49         unsigned int len;
  50         queueData( unsigned char tc_id, unsigned char *data, unsigned int len, __u8 prio = 0 )
  51                 :prio(prio), tc_id(tc_id), data(data), len(len)
  52         {
  53
  54         }
  55         bool operator < ( const struct queueData &a ) const
  56         {
  57                 return prio < a.prio;
  58         }
  59 };
  60
  61 struct _lpduQueueElem
  62 {
  63         unsigned char lpduLen;
  64         unsigned char lpdu[PCMCIABUFLEN];
  65         ptrlpduQueueElem nextElem;
  66 };
  67
  68 struct _lpduQueueHeader
  69 {
  70         long numLPDUS;
  71         ptrlpduQueueElem firstLPDU;
  72 };
  73
  74 #define CIServiceMap std::map<int, std::list<tempPMT_t> >
  75
  76 class eDVBCI: private eThread, public eMainloop, public Object
  77 {
  78         static int instance_count;
  79         std::priority_queue<queueData> sendqueue;
  80         bool newTransponder;
  81 protected:
  82         enum
  83         {
  84                 stateInit, stateError, statePlaying, statePause
  85         };
  86         int state;
  87         int fd;
  88         eSocketNotifier *ci;
  89
  90         int ci_state;
  91         int buffersize;
  92
  93         eTimer pollTimer;
  94
  95         int tempPMTentrys;
  96
  97         CIServiceMap services;
  98         std::map<int,int> versions;
  99
 100         struct session_struct sessions[32];
 101
 102         char appName[256];
 103         unsigned short caids[256];
 104         unsigned int caidcount;
 105
 106         unsigned char ml_buffer[1024];
 107         int ml_bufferlen;
 108         int ml_buffersize;
 109
 110         //----------------------
 111         lpduQueueHeader lpduReceiveQueues[MAXTRANSPORTSESSIONS];
 112
 113         ptrlpduQueueElem eDVBCI::AllocLpduQueueElem(unsigned char t_c_id);
 114         int eDVBCI::lpduQueueElemIsMore(ptrlpduQueueElem curElem);
 115
 116         //----------------------
 117
 118         void clearCAIDs();
 119         void addCAID(int caid);
 120         void pushCAIDs();
 121         void addService(int program);
 122         void PMTflush(int program);
 123         void PMTaddPID(int sid, int pid,int streamtype);
 124         void PMTaddDescriptor(int sid, unsigned char *data);
 125         void PMTsetVersion(int sid, int version);
 126         void newService();
 127         void create_sessionobject(unsigned char *tag,unsigned char *data,unsigned int len,int session);
 128
 129         bool sendData(unsigned char tc_id,unsigned char *data,unsigned int len);
 130         void sendTPDU(unsigned char tpdu_tag,unsigned int len,unsigned char tc_id,unsigned char *data,bool dontQueue=false);
 131         void help_manager(unsigned int session);
 132         void app_manager(unsigned int session);
 133         void ca_manager(unsigned int session);
 134
 135         void handle_session(unsigned char *data,int len);
 136         int service_available(unsigned long service_class);
 137         void handle_spdu(unsigned int tpdu_tc_id,unsigned char *data,int len);
 138         void receiveTPDU(unsigned char tpdu_tag,unsigned int len,unsigned char tpdu_tc_id,unsigned char *data);
 139         void incoming(unsigned char *buffer,int len);
 140         void dataAvailable(int what);
 141         void poll();
 142         void startTimer();
 143         void stopTimer();
 144         void updateCIinfo(unsigned char *buffer);
 145
 146         void mmi_begin();
 147         void mmi_end();
 148         void mmi_enqansw(unsigned char *answ);
 149         void mmi_menuansw(int);
 150
 151 public:
 152         struct eDVBCIMessage
 153         {
 154                 enum
 155                 {
 156                         start,
 157                         reset,
 158                         init,
 159                         exit,
 160                         go,
 161                         PMTsetVersion,
 162                         PMTflush,
 163                         PMTaddPID,
 164                         PMTaddDescriptor,
 165                         mmi_begin,
 166                         mmi_end,
 167                         mmi_enqansw,
 168                         mmi_menuansw,
 169                         getcaids,
 170                         enable_ts,
 171                         disable_ts,
 172                         getAppName
 173                 };
 174                 int type;
 175                 int sid;
 176                 unsigned char *data;
 177                 int pid;
 178                 int streamtype;
 179
 180                 eDVBCIMessage() { }
 181                 eDVBCIMessage(int type): type(type) { }
 182                 eDVBCIMessage(int type, int sid, unsigned char *data): type(type),sid(sid),data(data) { }
 183                 eDVBCIMessage(int type, int sid): type(type),sid(sid) { }
 184                 eDVBCIMessage(int type, int sid, int pid, int streamtype): type(type),sid(sid),pid(pid),streamtype(streamtype) { }
 185
 186         };
 187         eFixedMessagePump<eDVBCIMessage> messages;
 188
 189         void gotMessage(const eDVBCIMessage &message);
 190
 191         eDVBCI();
 192         ~eDVBCI();
 193
 194         void thread();
 195         Signal1<void, const char*> ci_progress;
 196         Signal2<void, const char*, int> ci_mmi_progress;
 197 };
 198 #endif