commit f8b22bfe5568813f22fc22baea6eb494144f66e1
author Alexander Afanasyev <alexander.afanasyev@ucla.edu> Sat Jan 26 17:28:11 2013 -0800
committer Alexander Afanasyev <alexander.afanasyev@ucla.edu> Sat Jan 26 17:28:11 2013 -0800
tree 92f49a642582520988b7269222d5d771247cae81
parent eb575e09dfae4fa06e30882fee6ad3aaa45bcfdc

Correction of fetcher

src/fetch-manager.cc

diff --git a/src/fetch-manager.cc b/src/fetch-manager.cc
index e185581..4c0ba02 100644
--- a/src/fetch-manager.cc
+++ b/src/fetch-manager.cc
@@ -96,6 +96,7 @@
       break;
     }
 
+  _LOG_DEBUG ("Reschedule fetcher task");
   m_scheduler->rescheduleTaskAt (m_scheduleFetchesTask, 0);
   // ScheduleFetches (); // will start a fetch if m_currentParallelFetches is less than max, otherwise does nothing
 }
@@ -112,10 +113,16 @@
        item++)
     {
       if (item->IsActive ())
-        continue;
+        {
+          _LOG_DEBUG ("Item is active");
+          continue;
+        }
 
       if (currentTime < item->GetNextScheduledRetry ())
-        continue;
+        {
+          _LOG_DEBUG ("Item is delayed");
+          continue;
+        }
 
       _LOG_DEBUG ("Start fetching of " << item->GetName ());
 

src/fetcher.cc

diff --git a/src/fetcher.cc b/src/fetcher.cc
index 9c1475d..a67f76a 100644
--- a/src/fetcher.cc
+++ b/src/fetcher.cc
@@ -63,7 +63,7 @@
   , m_pipeline (6) // initial "congestion window"
   , m_activePipeline (0)
   , m_retryPause (0)
-  , m_nextScheduledRetry () // zero time
+  , m_nextScheduledRetry (date_time::second_clock<boost::posix_time::ptime>::universal_time ())
 {
 }