From: leslie <unknown>
Date: Wed, 12 Aug 2009 02:38:24 +0000 (+0800)
Subject: trigger rebuild caid list if smartcard/cardclient change handled caid
X-Git-Tag: upstream/620~207
X-Git-Url: http://www.vanbest.org/gitweb/?a=commitdiff_plain;h=ef6d5f8b9204d59e4121e40fd6a8157516845186;p=sasc-ng.git

trigger rebuild caid list if smartcard/cardclient change handled caid
---

diff --git a/cam.c b/cam.c
index 5561e0e..dad0adf 100644
--- a/cam.c
+++ b/cam.c
@@ -58,7 +58,6 @@
 #define ECM_DATA_TIME    6000 // time to wait for ECM data updates
 #define MAX_ECM_IDLE   300000 // delay before an idle handler can be removed
 #define MAX_ECM_HOLD    15000 // delay before an idle handler stops processing
-#define CAID_TIME      300000 // time between caid scans
 
 #define ECMCACHE_FILE "ecm.cache"
 
@@ -865,7 +864,7 @@ for(cPrgPid *pid=pids.First(); pid; pid=pids.Next(pid)) {
   return HasPidCaDescr();
 }
 
-// -- cEcmSys ------------------------------------------------------------------
+// -- cEcmPri ------------------------------------------------------------------
 
 class cEcmPri : public cSimpleItem {
 public:
@@ -1973,6 +1972,9 @@ void cChannelList::Purge(int caid, bool fullch)
 
 // -- cScCiAdapter -------------------------------------------------------------
 
+#define CAID_TIME      300000 // time between caid scans
+#define TRIGGER_TIME    10000 // min. time between caid scan trigger
+
 #define TDPU_SIZE_INDICATOR 0x80
 
 struct TPDU {
@@ -1994,10 +1996,11 @@ private:
   cRingBufferLinear *rb;
   cScCamSlot *slots[MAX_CI_SLOTS];
   //
-  cTimeMs caidTimer;
+  cTimeMs caidTimer, triggerTimer;
   int version[MAX_CI_SLOTS];
   caid_t caids[MAX_CI_SLOTS][MAX_CI_SLOT_CAIDS+1];
   int tcid;
+  bool rebuildcaids;
   //
   cTimeMs readTimer, writeTimer;
   //
@@ -2015,6 +2018,7 @@ public:
   void CamAddPrg(cPrg *prg);
   bool CamSoftCSA(void);
   int GetCaids(int slot, unsigned short *Caids, int max);
+  void CaidsChanged(void);
   };
 
 // -- cScCamSlot ---------------------------------------------------------------
@@ -2224,7 +2228,7 @@ void cScCamSlot::Process(const unsigned char *data, int len)
 cScCiAdapter::cScCiAdapter(cDevice *Device, int CardIndex, cCam *Cam)
 {
   device=Device; cardIndex=CardIndex; cam=Cam;
-  tcid=0;
+  tcid=0; rebuildcaids=false;
   memset(version,0,sizeof(version));
   memset(slots,0,sizeof(slots));
   SetDescription("SC-CI adapter on device %d",cardIndex);
@@ -2283,9 +2287,14 @@ int cScCiAdapter::GetCaids(int slot, unsigned short *Caids, int max)
   return version[slot];
 }
 
+void cScCiAdapter::CaidsChanged(void)
+{
+  rebuildcaids=true;
+}
+
 void cScCiAdapter::BuildCaids(bool force)
 {
-  if(caidTimer.TimedOut() || force) {
+  if(caidTimer.TimedOut() || force || (rebuildcaids && triggerTimer.TimedOut())) {
     PRINTF(L_CORE_CAIDS,"%d: building caid lists",cardIndex);
     cChannelList list(cardIndex);
     Channels.Lock(false);
@@ -2329,6 +2338,8 @@ void cScCiAdapter::BuildCaids(bool force)
     ciMutex.Unlock();
 
     caidTimer.Set(CAID_TIME);
+    triggerTimer.Set(TRIGGER_TIME);
+    rebuildcaids=false;
     }
 }
 
@@ -3048,6 +3059,14 @@ bool cScDvbDevice::SoftCSA(bool live)
   return softcsa && (!fullts || !live);
 }
 
+void cScDvbDevice::CaidsChanged(void)
+{
+#if APIVERSNUM >= 10500
+  if(ciadapter) ciadapter->CaidsChanged();
+  PRINTF(L_CORE_CAIDS,"caid list rebuild triggered");
+#endif
+}
+
 bool cScDvbDevice::SetCaDescr(ca_descr_t *ca_descr, bool initial)
 {
   if(!softcsa || (fullts && ca_descr->index==0)) {
@@ -3181,6 +3200,9 @@ bool cScDvbDevice::Initialize(void)
   return true;
 }
 
+void cScDvbDevice::CaidsChanged(void)
+{}
+
 bool cScDvbDevice::SoftCSA(bool live)
 {
   return softcsa && !live;
diff --git a/cam.h b/cam.h
index df2f5c9..61cfef3 100644
--- a/cam.h
+++ b/cam.h
@@ -235,6 +235,7 @@ public:
   void DumpAV7110(void);
   cCam *Cam(void) { return cam; }
   bool SoftCSA(bool live);
+  void CaidsChanged(void);
   };
 
 #endif // ___CAM_H
diff --git a/sc.c b/sc.c
index fc74767..8f9afbf 100644
--- a/sc.c
+++ b/sc.c
@@ -1064,6 +1064,14 @@ bool cSoftCAM::TriggerHook(int CardNum, int id)
   return dev && dev->Cam() && dev->Cam()->TriggerHook(id);
 }
 
+void cSoftCAM::CaidsChanged(void)
+{
+  for(int n=cDevice::NumDevices(); --n>=0;) {
+    cScDvbDevice *dev=dynamic_cast<cScDvbDevice *>(cDevice::GetDevice(n));
+    if(dev) dev->CaidsChanged();
+    }
+}
+
 // --- cScHousekeeper ----------------------------------------------------------
 
 class cScHousekeeper : public cThread {
diff --git a/sc.h b/sc.h
index cb8f4fe..618ea55 100644
--- a/sc.h
+++ b/sc.h
@@ -35,6 +35,7 @@ public:
   static void SetLogStatus(int CardNum, const cEcmInfo *ecm, bool on);
   static void AddHook(int CardNum, cLogHook *hook);
   static bool TriggerHook(int CardNum, int id);
+  static void CaidsChanged(void);
   };
 
 #endif // ___SC_H
diff --git a/smartcard.c b/smartcard.c
index 448fc36..49b1644 100644
--- a/smartcard.c
+++ b/smartcard.c
@@ -32,6 +32,7 @@
 #include <vdr/thread.h>
 
 #include "smartcard.h"
+#include "sc.h"
 #include "misc.h"
 #include "log-core.h"
 
@@ -1879,6 +1880,11 @@ int cSmartCard::CheckSctLen(const unsigned char *data, int off)
   return l;
 }
 
+void cSmartCard::CaidsChanged(void)
+{
+  cSoftCAM::CaidsChanged();
+}
+
 // -- cSmartCardLink -----------------------------------------------------------
 
 cSmartCardLink::cSmartCardLink(const char *Name, int Id)
diff --git a/smartcard.h b/smartcard.h
index db2439c..d889e43 100644
--- a/smartcard.h
+++ b/smartcard.h
@@ -127,6 +127,7 @@ protected:
   bool Status(void);
   void NewCardConfig(const struct CardConfig *Cfg);
   int CheckSctLen(const unsigned char *data, int off);
+  void CaidsChanged(void);
 public:
   cSmartCard(const struct CardConfig *Cfg, const struct StatusMsg *Msg);
   virtual ~cSmartCard() {};
diff --git a/systems/cardclient/camd.c b/systems/cardclient/camd.c
index 891341a..0216451 100644
--- a/systems/cardclient/camd.c
+++ b/systems/cardclient/camd.c
@@ -278,7 +278,9 @@ void cCardClientCamd33::HandleEMMRequest(const unsigned char *buff, int len)
 {
   if(len>=13 && buff[0]==0 && !CheckNull(buff,len) && memcmp(buff,lastEmmReq,13)) {
     emmProcessing=false;
-    CAID=buff[1]*256+buff[2];
+    int c=buff[1]*256+buff[2];
+    if(c!=CAID) CaidsChanged();
+    CAID=c;
     ResetIdSet();
     switch(CAID>>8) {
       case 0x17:
@@ -362,6 +364,7 @@ bool cCardClientBuffy::Login(void)
     if(caid==0xFFFF) break;
     if(caid) CAIDs[numCAIDs++]=caid;
     }
+  CaidsChanged();
   LBSTART(L_CC_LOGIN);
   LBPUT("%s: CAIDs ",name);
   for(int i=0; i<numCAIDs && CAIDs[i]; i++) LBPUT("%04X ",CAIDs[i]);
@@ -586,6 +589,7 @@ void cCardClientCamd35::HandleEMMRequest(const struct CmdBlock *cb)
 
     if(!emmAllowed) PRINTF(L_CC_EMM,"%s: EMM disabled from config",name);
     emmProcessing=true;
+    CaidsChanged();
     }
 }
 
diff --git a/systems/cardclient/cc.c b/systems/cardclient/cc.c
index c8bbb53..d2315f5 100644
--- a/systems/cardclient/cc.c
+++ b/systems/cardclient/cc.c
@@ -25,6 +25,7 @@
 
 #include "system.h"
 #include "cc.h"
+#include "sc.h"
 #include "network.h"
 #include "misc.h"
 #include "opts.h"
@@ -65,6 +66,11 @@ bool cCardClient::Immediate(void)
   return immediate;
 }
 
+void cCardClient::CaidsChanged(void)
+{
+  cSoftCAM::CaidsChanged();
+}
+
 bool cCardClient::ParseStdConfig(const char *config, int *num)
 {
   int n, emm=0;
diff --git a/systems/cardclient/cc.h b/systems/cardclient/cc.h
index 2e20456..a8f5eef 100644
--- a/systems/cardclient/cc.h
+++ b/systems/cardclient/cc.h
@@ -70,6 +70,7 @@ protected:
   virtual int RecvMsg(cNetSocket *so, unsigned char *data, int len, int to=-1);
   virtual bool Login(void) { return false; }
   bool Immediate(void);
+  void CaidsChanged(void);
 public:
   cCardClient(const char *Name);
   virtual bool Init(const char *config)=0;
diff --git a/systems/cardclient/cccam2.c b/systems/cardclient/cccam2.c
index 3b98f92..249527c 100644
--- a/systems/cardclient/cccam2.c
+++ b/systems/cardclient/cccam2.c
@@ -305,6 +305,7 @@ private:
 public:
   int GetShares(const cEcmInfo *ecm, cShares *ss);
   void SetLag(int shareid, int lag);
+  bool HasCaid(int caid);
   };
 
 cShare *cShares::Find(int shareid)
@@ -326,6 +327,13 @@ void cShares::SetLag(int shareid, int lag)
   Unlock();
 }
 
+bool cShares::HasCaid(int caid)
+{
+  for(cShare *s=First(); s; s=Next(s))
+    if(s->CaID()==caid) return true;
+  return false;
+}
+
 int cShares::GetShares(const cEcmInfo *ecm, cShares *ss)
 {
   Lock(true);
@@ -499,7 +507,9 @@ void cCardClientCCcam2::PacketAnalyzer(const struct CmdHeader *hdr, int length)
           cShare *n=shares.Next(s);
           if(s->ShareID()==shareid) {
             PRINTF(L_CC_CCCAM2SH,"REMOVE share %08x caid: %04x",s->ShareID(),s->CaID());
+            int caid=s->CaID();
             shares.Del(s);
+            if(!shares.HasCaid(caid)) CaidsChanged();
             }
           s=n;
           }
@@ -511,6 +521,9 @@ void cCardClientCCcam2::PacketAnalyzer(const struct CmdHeader *hdr, int length)
         struct AddShare *add=(struct AddShare *)hdr;
         int caid=UINT16_BE(&add->caid);
         int shareid=UINT32_BE(&add->shareid);
+        shares.Lock(false);
+        if(!shares.HasCaid(caid)) CaidsChanged();
+        shares.Unlock();
         cShare *s=new cShare(shareid,caid,add->uphops);
         LBSTARTF(L_CC_CCCAM2SH);
         LBPUT("ADD share %08x hops %d maxdown %d caid %04x serial ",shareid,add->uphops,add->maxdown,caid);
diff --git a/systems/cardclient/newcamd.c b/systems/cardclient/newcamd.c
index 4bd6555..5487f92 100644
--- a/systems/cardclient/newcamd.c
+++ b/systems/cardclient/newcamd.c
@@ -421,7 +421,9 @@ bool cCardClientNewCamd::Login(void)
 
   if(!CmdSend(&so,MSG_CARD_DATA_REQ) || ReceiveMessage(&so,buffer,false)<=0) return false;
   if(buffer[0] == MSG_CARD_DATA) {
-    caId=(buffer[4]<<8)+buffer[5];
+    int c=(buffer[4]<<8)+buffer[5];
+    if(c!=caId) CaidsChanged();
+    caId=c;
     LBSTARTF(L_CC_LOGIN);
     char str[32], str2[32];
     LBPUT("%s: CaID=%04x admin=%d srvUA=%s",name,caId,buffer[3]==1,HexStr(str,&buffer[6],8));
diff --git a/systems/cardclient/radegast.c b/systems/cardclient/radegast.c
index 5893611..a4907a7 100644
--- a/systems/cardclient/radegast.c
+++ b/systems/cardclient/radegast.c
@@ -215,7 +215,8 @@ bool cCardClientRadegast::Login(void)
   else PRINTF(L_CC_RDGD,"no server hello, assuming old mode");
   if(emmProcessing && !emmAllowed) 
     PRINTF(L_CC_EMM,"%s: EMM disabled from config",name);
-  return true; 
+  CaidsChanged();
+  return true;
 }
 
 bool cCardClientRadegast::ProcessECM(const cEcmInfo *ecm, const unsigned char *source, unsigned char *cw, int cardnum)
diff --git a/systems/sc-conax/sc-conax.c b/systems/sc-conax/sc-conax.c
index f909519..f0facec 100644
--- a/systems/sc-conax/sc-conax.c
+++ b/systems/sc-conax/sc-conax.c
@@ -246,7 +246,12 @@ bool cSmartCardConax::Init(void)
   for(int i=0; i<l; i+=buff[i+1]+2) {
     switch(buff[i]) {
       case 0x20: cardVer=buff[i+2]; break;
-      case 0x28: sysId=(buff[i+2]<<8)+buff[i+3]; break;
+      case 0x28: {
+                 int s=(buff[i+2]<<8)+buff[i+3];
+                 if(s!=sysId) CaidsChanged();
+                 sysId=s;
+                 break;
+                 }
       case 0x2f: currency=(buff[i+2]<<8)+buff[i+3]; break;
       }
     }
diff --git a/systems/sc-cryptoworks/sc-cryptoworks.c b/systems/sc-cryptoworks/sc-cryptoworks.c
index 1f3eb7e..873b756 100644
--- a/systems/sc-cryptoworks/sc-cryptoworks.c
+++ b/systems/sc-cryptoworks/sc-cryptoworks.c
@@ -223,7 +223,7 @@ cSmartCardCryptoworks::cSmartCardCryptoworks(void)
 {
   static const unsigned char cwexp[] = { 0x01,0x00,0x01 };
   BN_bin2bn(cwexp,sizeof(cwexp),exp);
-  ucpkValid=false;
+  caid=0; ucpkValid=false;
 }
 
 int cSmartCardCryptoworks::GetLen(void)
@@ -285,7 +285,9 @@ bool cSmartCardCryptoworks::Init(void)
     return false;
     }
   memcpy(Caid,&buff[2],2);
-  caid=buff[2]*256+buff[3];
+  int c=buff[2]*256+buff[3];
+  if(c!=caid) CaidsChanged();
+  caid=c;
   if(ReadRecord(buff,0x80)<7) {
     PRINTF(L_SC_ERROR,"reading record 2f01/80 failed");
     return false;
diff --git a/systems/sc-irdeto/sc-irdeto.c b/systems/sc-irdeto/sc-irdeto.c
index 783b9ec..a62fc98 100644
--- a/systems/sc-irdeto/sc-irdeto.c
+++ b/systems/sc-irdeto/sc-irdeto.c
@@ -399,7 +399,9 @@ static const struct CardConfig cardCfg = {
 
 cSmartCardIrdeto::cSmartCardIrdeto(void)
 :cSmartCard(&cardCfg,msgs)
-{}
+{
+  ACS=0; caId=0; numProv=0;
+}
 
 bool cSmartCardIrdeto::Init(void)
 {
@@ -419,7 +421,9 @@ bool cSmartCardIrdeto::Init(void)
     return false;
     }
   ACS=buff[8]*256+buff[9];
-  caId=buff[13]*256+buff[14];
+  int c=buff[13]*256+buff[14];
+  if(c!=caId) CaidsChanged();
+  caId=c;
   memcpy(coco,&buff[21],3); coco[3]=0;
   PRINTF(L_SC_INIT,"ACS Version %04x, CAID %04x, CoCo %s",ACS,caId,coco);
   snprintf(idStr,sizeof(idStr),"%s (ACS %x)",SC_NAME,ACS);
diff --git a/systems/sc-videoguard2/sc-videoguard2.c b/systems/sc-videoguard2/sc-videoguard2.c
index 7e98e1e..d114c8b 100644
--- a/systems/sc-videoguard2/sc-videoguard2.c
+++ b/systems/sc-videoguard2/sc-videoguard2.c
@@ -508,7 +508,7 @@ static const struct CardConfig cardCfgDelay = {
 cSmartCardVideoGuard2::cSmartCardVideoGuard2(void)
 :cSmartCard(&cardCfg,msgs)
 {
-  cmdList=0;
+  cmdList=0; CAID=0;
 }
 
 cSmartCardVideoGuard2::~cSmartCardVideoGuard2(void)
@@ -594,7 +594,9 @@ bool cSmartCardVideoGuard2::Init(void)
     return false;
     }
   
-  CAID=WORD(buff,0x1D,0xFFFF);
+  unsigned int c=WORD(buff,0x1D,0xFFFF);
+  if(c!=CAID) CaidsChanged();
+  CAID=c;
   memcpy(&cardID,&buff[8],4);
   memcpy(&groupID,&buff[8],4); groupID[3]=0;
   SetCard(new cCardNDS(cardID));