if(r < 0)
eWarning("ERROR reading from CI - %m\n");
- if(!se) {
+ if(state != stateInserted) {
+ state = stateInserted;
eDebug("ci inserted");
- se = new eDVBCISession(this);
-
+
/* enable HUP to detect removal or errors */
notifier_event->start();
}
if(r > 0)
- se->receiveData(data, r);
+ eDVBCISession::receiveData(this, data, r);
}
void eDVBCISlot::event(int)
{
+ state = stateRemoved;
+
eDebug("CI removed");
/* kill the TransportConnection */
notifier_event->stop();
}
-eDVBCISlot::eDVBCISlot(eMainloop *context, int nr): se(0)
+eDVBCISlot::eDVBCISlot(eMainloop *context, int nr)
{
char filename[128];
/* DVB CI Transport Connection */
#include <lib/dvb_ci/dvbci_session.h>
-
-eDVBCISession::eDVBCISession(eDVBCISlot *cislot)
-{
- slot = cislot;
-}
+#include <lib/dvb_ci/dvbci_resmgr.h>
int eDVBCISession::buildLengthField(unsigned char *pkt, int len)
{
return (pkt[0] & 0x7F) + 1;
}
+void eDVBCISession::sendAPDU(const unsigned char *tag, const void *data, int len)
+{
+ unsigned char pkt[len+3+4];
+ int l;
+ memcpy(pkt, tag, 3);
+ l=buildLengthField(pkt+3, len);
+ if (data)
+ memcpy(pkt+3+l, data, len);
+ sendSPDU(0x90, 0, 0, pkt, len+3+l);
+}
+
void eDVBCISession::sendSPDU(eDVBCISlot *slot, unsigned char tag, const void *data, int len, unsigned short session_nb, const void *apdu,int alen)
{
unsigned char pkt[4096];
sendSPDU(slot, 0x92, pkt, 5, session_nb);
}
+void eDVBCISession::recvCreateSessionResponse(const unsigned char *data)
+{
+ status = data[0];
+ state = stateStarted;
+ action = 1;
+ printf("create Session Response, status %x\n", status);
+}
+
+void eDVBCISession::recvCloseSessionRequest(const unsigned char *data)
+{
+ state = stateInDeletion;
+ action = 1;
+ printf("close Session Request\n");
+}
+
eDVBCISession *eDVBCISession::createSession(eDVBCISlot *slot, const unsigned char *resource_identifier, unsigned char &status)
{
eDVBCISession *session;
switch (tag)
{
case 0x00010041:
-// session=new eDVBCIResourceManagerSession;
+ session=new eDVBCIResourceManagerSession;
printf("RESOURCE MANAGER\n");
break;
case 0x00020041:
return session;
}
-void eDVBCISession::receiveData(const unsigned char *ptr, size_t len)
+void eDVBCISession::receiveData(eDVBCISlot *slot, const unsigned char *ptr, size_t len)
{
const unsigned char *pkt = (const unsigned char*)ptr;
unsigned char tag = *pkt++;
session->action=1;
}
}
+ else
+ {
+ unsigned session_nb;
+ session_nb=pkt[hlen-2]<<8;
+ session_nb|=pkt[hlen-1]&0xFF;
+
+ if ((!session_nb) || (session_nb >= SLMS))
+ {
+ printf("PROTOCOL: illegal session number %x\n", session_nb);
+ return;
+ }
+
+ session=sessions[session_nb-1];
+ if (!session)
+ {
+ printf("PROTOCOL: data on closed session %x\n", session_nb);
+ return;
+ }
+
+ switch (tag)
+ {
+ case 0x90:
+ break;
+ case 0x94:
+ session->recvCreateSessionResponse(pkt);
+ break;
+ case 0x95:
+ printf("recvCloseSessionRequest\n");
+ session->recvCloseSessionRequest(pkt);
+ break;
+ default:
+ printf("INTERNAL: nyi, tag %02x.\n", tag);
+ return;
+ }
+ }
+
+ hlen += llen + 1; // lengthfield and tag
+
+ pkt = ((const unsigned char*)ptr) + hlen;
+ len -= hlen;
+
+ if (session)
+ while (len > 0)
+ {
+ int alen;
+ const unsigned char *tag=pkt;
+ pkt+=3; // tag
+ len-=3;
+ hlen=parseLengthField(pkt, alen);
+ pkt+=hlen;
+ len-=hlen;
+
+ //if (eDVBCIModule::getInstance()->workarounds_active & eDVBCIModule::workaroundMagicAPDULength)
+ //{
+ // if (((len-alen) > 0) && ((len - alen) < 3))
+ // {
+ // printf("WORKAROUND: applying work around MagicAPDULength\n");
+ // alen=len;
+ // }
+ //}
+ if (session->receivedAPDU(tag, pkt, alen))
+ session->action = 1;
+ pkt+=alen;
+ len-=alen;
+ }
+
+ if (len)
+ printf("PROTOCOL: warning, TL-Data has invalid length\n");
}
{
static eDVBCISession *sessions[SLMS];
static eDVBCISession *eDVBCISession::createSession(eDVBCISlot *slot, const unsigned char *resource_identifier, unsigned char &status);
- void eDVBCISession::sendSPDU(eDVBCISlot *slot, unsigned char tag,const void *data, int len, unsigned short session_nb, const void *apdu=0,int alen=0);
- void sendOpenSessionResponse(eDVBCISlot *slot,unsigned char session_status, const unsigned char *resource_identifier,unsigned short session_nb);
+ static void eDVBCISession::sendSPDU(eDVBCISlot *slot, unsigned char tag,const void *data, int len, unsigned short session_nb, const void *apdu=0,int alen=0);
+ static void sendOpenSessionResponse(eDVBCISlot *slot,unsigned char session_status, const unsigned char *resource_identifier,unsigned short session_nb);
+ void recvCreateSessionResponse(const unsigned char *data);
+ void recvCloseSessionRequest(const unsigned char *data);
protected:
int state;
int status;
int action;
eDVBCISlot *slot; //base only
unsigned short session_nb;
+ virtual int receivedAPDU(const unsigned char *tag, const void *data, int len) = 0;
+ void eDVBCISession::sendAPDU(const unsigned char *tag, const void *data=0,int len=0);
public:
- eDVBCISession(eDVBCISlot *cislot);
- ~eDVBCISession();
-
enum { stateInCreation, stateBusy, stateInDeletion, stateStarted, statePrivate};
- int parseLengthField(const unsigned char *pkt, int &len);
- int buildLengthField(unsigned char *pkt, int len);
+ static int parseLengthField(const unsigned char *pkt, int &len);
+ static int buildLengthField(unsigned char *pkt, int len);
- void receiveData(const unsigned char *ptr, size_t len);
+ static void receiveData(eDVBCISlot *slot, const unsigned char *ptr, size_t len);
int getState() { return state; }
int getStatus() { return status; }