commit ff8d9dc9f6ff3cf3b3ccd74cbe603cab8517dae0
author Alexander Afanasyev <alexander.afanasyev@ucla.edu> Sat Jan 26 00:45:08 2013 -0800
committer Alexander Afanasyev <alexander.afanasyev@ucla.edu> Sat Jan 26 00:45:08 2013 -0800
tree 320f83116fe1ff9c8787298ac37d32617df4870d
parent 0c545ed1cafdf953a50d7cf4e3f21ff28842d6e0

Adding executor to fetcher: there was a deadlock otherwise

src/fetch-manager.cc

diff --git a/src/fetch-manager.cc b/src/fetch-manager.cc
index 3b5f181..d74f210 100644
--- a/src/fetch-manager.cc
+++ b/src/fetch-manager.cc
@@ -25,7 +25,7 @@
 #include <boost/throw_exception.hpp>
 #include "logging.h"
 
-INIT_LOGGER ("Fetch.Manager");
+INIT_LOGGER ("FetchManager");
 
 using namespace boost;
 using namespace std;
@@ -100,6 +100,8 @@
       if (item->IsActive ())
         continue;
 
+      _LOG_DEBUG ("Start fetching of " << item->GetName ());
+
       m_currentParallelFetches ++;
       item->RestartPipeline ();
     }
@@ -108,6 +110,8 @@
 void
 FetchManager::DidNoDataTimeout (Fetcher &fetcher)
 {
+  _LOG_DEBUG ("No data timeout for " << fetcher.GetName () << " with forwarding hint: " << fetcher.GetForwardingHint ());
+
   fetcher.SetForwardingHint (Ccnx::Name (BROADCAST_DOMAIN));
   {
     unique_lock<mutex> lock (m_parellelFetchMutex);