Ticket #892: eitratelimit_#892_8612.patch

libs/libmythtv/eithelper.h

@@ -20 +20 @@
 {
     Q_OBJECT
   public:
-    EITHelper() : QObject(NULL, "EITHelper") { ; }
+    EITHelper() : QObject(NULL, "EITHelper") 
+    { 
+        events_full = false; 
+    }
 
     void ClearList(void);
     uint GetListSize(void) const;
@@ -28 +31 @@
 
   public slots:
     void HandleEITs(QMap_Events* events);
+  signals:
+    void StopParsing(bool);
 
   private:
     int GetChanID(int tid_db, const Event &event) const;
@@ -39 +44 @@
 
     /// Maximum number of DB inserts per ProcessEvents call.
     static const uint kChunkSize;
+
+    // Max event list size before we stop parsing incoming events
+    // allowing us to try and catchup.
+    static const uint kMAXChunkSize;
+
+    bool events_full;
 };
 
 #endif // USING_DVB

libs/libmythtv/siparser.cpp

@@ -64 +64 @@
     ParserInReset(false),           standardChange(false),
     PrivateTypesLoaded(false)
 {
+    events_full = false;
+
     /* Set the PrivateTypes to default values */
     PrivateTypes.reset();
 
@@ -515 +517 @@
     (void) pid;
 #endif
 
+    if (events_full)
+    {
+        pmap_lock.unlock();
+        return;
+    }
+
     if (!(buffer[1] & 0x80))
     {
         VERBOSE(VB_SIPARSER, LOC + 

libs/libmythtv/eithelper.cpp

@@ -4 +4 @@
 #include "eithelper.h"
 #include "mythdbcon.h"
 
+
+// TODO: Should these be configurable values based on how much ram a 
+// backend has available?
 const uint EITHelper::kChunkSize = 20;
+const uint EITHelper::kMAXChunkSize = 2000;
 
 static int get_chan_id_from_db(int tid_db, const Event&);
 static uint update_eit_in_db(MSqlQuery&, MSqlQuery&, int, const Event&);
@@ -75 +79 @@
     if (!eitList.size())
         return 0;
 
+    //VERBOSE(VB_EIT,QString("EITHelper::ProcessEvents: Events: %1/%2")
+    //        .arg(eitList.size()).arg(eitList.front()->size()));
+
     uint insertCount = 0;
-    if (eitList.front()->size() <= kChunkSize)
+
+    QList_Events  subset;
+    while (subset.size() < kChunkSize && eitList.size())
     {
         QList_Events *events = eitList.front();
-        eitList.pop_front();
+        while (subset.size() < kChunkSize && events->size())
+        {
+            subset.push_back(events->front());
+            events->pop_front();
+        }
+        if (! events->size())
+        {
+            eitList.pop_front();
+            delete events;
+        }
+    }
 
-        eitList_lock.unlock();
-        insertCount += UpdateEITList(mplexid, *events);
-        QList_Events::iterator it = events->begin();
-        for (; it != events->end(); ++it)
-            delete *it;
-        delete events;
-        eitList_lock.lock();
-    }
-    else
+    eitList_lock.unlock();
+    insertCount += UpdateEITList(mplexid, subset);
+    QList_Events::iterator it = subset.begin();
+    for (; it != subset.end(); ++it)
+        delete *it;
+    eitList_lock.lock();
+
+    if (((eitList.size() <= kChunkSize) && events_full) 
+          || ((eitList.size() > kMAXChunkSize) && !events_full))
     {
-        QList_Events *events = eitList.front();
-        QList_Events  subset;
+        int size = eitList.size();
+        VERBOSE(VB_GENERAL, QString ("EITHelper: ToggleParsing EIT (%1)")
+                                      .arg(size));
 
-        QList_Events::iterator subset_end = events->begin();
-        for (uint i = 0; i < kChunkSize; ++i) ++subset_end;
-        subset.insert(subset.end(), events->begin(), subset_end);
-        events->erase(events->begin(), subset_end);
-        
+        events_full = (size > kMAXChunkSize);
+
         eitList_lock.unlock();
-        insertCount += UpdateEITList(mplexid, subset);
-        QList_Events::iterator it = subset.begin();
-        for (; it != subset.end(); ++it)
-            delete *it;
+        emit(StopParsing(events_full));
         eitList_lock.lock();
     }
 

libs/libmythtv/eitscanner.cpp

@@ -176 +176 @@
             eitHelper, SLOT(HandleEITs(QMap_Events*)));
     connect(channel,   SIGNAL(UpdatePMTObject(const PMTObject *)),
             this,      SLOT(SetPMTObject(const PMTObject *)));
+    connect(eitHelper, SIGNAL(StopParsing(bool)),
+            parser,    SLOT(StopParsing(bool)));
 }
 
 /** \fn EITScanner::StopPassiveScan(void)

libs/libmythtv/siparser.h

@@ -111 +111 @@
 
   public slots:
     virtual void deleteLater(void);
+    void StopParsing(bool stop)
+         { pmap_lock.lock(); events_full = stop; pmap_lock.unlock(); }
 
   signals:
     void FindTransportsComplete(void);
@@ -279 +281 @@
     // statistics
     QMap<uint,uint>     descCount;
     mutable QMutex      descLock;
+
+    bool events_full;
 };
 
 #endif // SIPARSER_H