Timeouts, keepalives...

diff --git a/command.cc b/command.cc
index a2b1968741cd6bce33140c5c41707cf8a7cf0655..910db61a8b3bec0818338b1786c8361fe90cdfb9 100644 (file)
--- a/command.cc
+++ b/command.cc
@@ -525,6 +525,7 @@ void Command::doFromTheTop(bool which)
 {
   if (which)
   {
+    logger->log("Command", Log::NOTICE, "Doing connection lost dialog");
     connLost = new VInfo();
     connLost->setSize(360, 200);
     connLost->createBuffer();

diff --git a/eventdispatcher.cc b/eventdispatcher.cc
index b03f23d86d8d7861912ae51954c34dcba6b4ebe1..9a732355636a16579c162e3069068841f62e223e 100644 (file)
--- a/eventdispatcher.cc
+++ b/eventdispatcher.cc
@@ -111,7 +111,8 @@ void EventDispatcher::edUnregister(EDReceiver* edr)
     if (*i == edr) break; // found
   }
 
-  if (i == receivers.end()) abort(); // should never happen
+  if (i == receivers.end()) return; // Not in the list. Already unregistered? Perhaps vdr::connectionDied already removed this streamclient
+  // FIXME, this should probably be done another way. A call to edUnregister with an object that may or may not be in the list? Not good.
 
   if (!edr->callinprogress)
   {

diff --git a/playerlivetv.cc b/playerlivetv.cc
index 6295ee90d6410c4cb133bec3398b054e19327c25..85230eb4d4990d48aa1498eb6a767daf6019afb4 100644 (file)
--- a/playerlivetv.cc
+++ b/playerlivetv.cc
@@ -505,7 +505,7 @@ bool PlayerLiveTV::checkError()
 {
   if (!vdr->isConnected())
   {
-    switchState(S_STOP);
+    if (state != S_STOP) switchState(S_STOP);
     
     Message* m = new Message();
     m->from = this;

diff --git a/vdr.cc b/vdr.cc
index 31f0d471415d79da34b31c20df5c849e38a6eee7..0e1ba97fd669e6bacb8cde4d4644d7178dcfb7ac 100644 (file)
--- a/vdr.cc
+++ b/vdr.cc
@@ -234,7 +234,7 @@ void VDR::threadMethod()
 
       if (!tcp->isConnected()) { connectionDied(); return; } // return to stop this thread
       
-      timeoutCount = 0; // disable it for now
+     timeoutCount = 0; // disable it for now
       
       if (timeoutCount >= 10) //20s
       {
@@ -244,6 +244,7 @@ void VDR::threadMethod()
         
         if (lastKAsent == 0)
         {
+          logger->log("VDR", Log::DEBUG, "Sending KA packet");
           if (!sendKA(timeNow)) { connectionDied(); return; }
           lastKAsent = timeNow;
           continue;
@@ -325,6 +326,7 @@ void VDR::threadMethod()
       {
         lastKAsent = 0;
         timeoutCount = 0;
+        logger->log("VDR", Log::ERR, "Rxd correct KA reply");
       }
     }
     else
@@ -386,7 +388,10 @@ void VDR::connectionDied()
         logger->log("VDR", Log::ERR, "Timeouts: no waiting stream receiver found for streamid %lu !!!", vdrpr->streamID);
         delete vresp;
       }
-      edLock();  
+      edLock();
+      
+      for(EDRL::iterator i = receivers.begin(); i != receivers.end(); i++)
+        if ((VDR_PacketReceiver*)*i == vdrpr) { receivers.erase(i); break; }
     }
   }
   edUnlock();
@@ -426,6 +431,7 @@ VDR_ResponsePacket* VDR::RequestResponse(VDR_RequestPacket* vrp)
 
   if (!connected)
   {
+    logger->log("VDR", Log::DEBUG, "RR when !connected");
     VDR_ResponsePacket* vresp = new VDR_ResponsePacket();
     return vresp; // "no-response" return
   }