1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
|
#ifndef __dvbci_dvbci_h
#define __dvbci_dvbci_h
#ifndef SWIG
#include <lib/base/ebase.h>
#include <lib/service/iservice.h>
#include <lib/python/python.h>
#include <set>
#include <queue>
class eDVBCISession;
class eDVBCIApplicationManagerSession;
class eDVBCICAManagerSession;
class eDVBCIMMISession;
class eDVBServicePMTHandler;
class eDVBCISlot;
class eDVBCIInterfaces;
struct queueData
{
__u8 prio;
unsigned char *data;
unsigned int len;
queueData( unsigned char *data, unsigned int len, __u8 prio = 0 )
:prio(prio), data(data), len(len)
{
}
bool operator < ( const struct queueData &a ) const
{
return prio < a.prio;
}
};
enum data_source
{
TUNER_A, TUNER_B, TUNER_C, TUNER_D, CI_A, CI_B, CI_C, CI_D
};
class eDVBCISlot: public iObject, public Object
{
friend class eDVBCIInterfaces;
DECLARE_REF(eDVBCISlot);
private:
int slotid;
int fd;
eSocketNotifier *notifier;
int state;
std::map<uint16_t, uint8_t> running_services;
eDVBCIApplicationManagerSession *application_manager;
eDVBCICAManagerSession *ca_manager;
eDVBCIMMISession *mmi_session;
std::priority_queue<queueData> sendqueue;
std::set<uint16_t> possible_caids;
std::set<eServiceReference> possible_services;
std::set<std::string> possible_providers;
int use_count;
eDVBCISlot *linked_next; // needed for linked CI handling
data_source current_source;
int current_tuner;
void data(int);
public:
enum {stateRemoved, stateInserted, stateInvalid, stateResetted};
eDVBCISlot(eMainloop *context, int nr);
~eDVBCISlot();
int send(const unsigned char *data, size_t len);
void setAppManager( eDVBCIApplicationManagerSession *session );
void setMMIManager( eDVBCIMMISession *session );
void setCAManager( eDVBCICAManagerSession *session );
eDVBCIApplicationManagerSession *getAppManager() { return application_manager; }
eDVBCIMMISession *getMMIManager() { return mmi_session; }
eDVBCICAManagerSession *getCAManager() { return ca_manager; }
int getState() { return state; }
int getSlotID();
int reset();
int startMMI();
int stopMMI();
int answerText(int answer);
int answerEnq(char *value);
int cancelEnq();
int getMMIState();
int sendCAPMT(eDVBServicePMTHandler *ptr, const std::vector<uint16_t> &caids=std::vector<uint16_t>());
void removeService(uint16_t program_number=0xFFFF);
int getNumOfServices() { return running_services.size(); }
int setSource(data_source source);
};
struct CIPmtHandler
{
eDVBServicePMTHandler *pmthandler;
eDVBCISlot *cislot;
CIPmtHandler()
:pmthandler(NULL), cislot(NULL)
{}
CIPmtHandler( const CIPmtHandler &x )
:pmthandler(x.pmthandler), cislot(x.cislot)
{}
CIPmtHandler( eDVBServicePMTHandler *ptr )
:pmthandler(ptr), cislot(NULL)
{}
bool operator==(const CIPmtHandler &x) const { return x.pmthandler == pmthandler; }
};
typedef std::list<CIPmtHandler> PMTHandlerList;
#endif // SWIG
class eDVBCIInterfaces
{
DECLARE_REF(eDVBCIInterfaces);
static eDVBCIInterfaces *instance;
private:
eSmartPtrList<eDVBCISlot> m_slots;
eDVBCISlot *getSlot(int slotid);
PMTHandlerList m_pmt_handlers;
#ifndef SWIG
public:
#endif
eDVBCIInterfaces();
~eDVBCIInterfaces();
void addPMTHandler(eDVBServicePMTHandler *pmthandler);
void removePMTHandler(eDVBServicePMTHandler *pmthandler);
void recheckPMTHandlers();
void gotPMT(eDVBServicePMTHandler *pmthandler);
void ciRemoved(eDVBCISlot *slot);
int getSlotState(int slot);
int reset(int slot);
int initialize(int slot);
int startMMI(int slot);
int stopMMI(int slot);
int answerText(int slot, int answer);
int answerEnq(int slot, char *value);
int cancelEnq(int slot);
int getMMIState(int slot);
int sendCAPMT(int slot);
int setInputSource(int tunerno, data_source source);
#ifdef SWIG
public:
#endif
static eDVBCIInterfaces *getInstance();
int getNumOfSlots() { return m_slots.size(); }
PyObject *getDescrambleRules(int slotid);
RESULT setDescrambleRules(int slotid, SWIG_PYOBJECT(ePyObject) );
};
#endif
|
