Changing naming convention
Format for files: /<forwarding-hint>/<appname>/file/<hash>/<device_name>/<segment>
Format for actions: /<forwarding-hint>/<appname>/<shared-folder>/action/<device_name>/<action-seq>
All tests pass
Change-Id: Ie42c0f29813839ca7cc42fa52b5c3f246da2e130
diff --git a/src/fetch-manager.cc b/src/fetch-manager.cc
index 7e087ce..d152c30 100644
--- a/src/fetch-manager.cc
+++ b/src/fetch-manager.cc
@@ -72,9 +72,10 @@
FetchManager::~FetchManager ()
{
m_scheduler->shutdown ();
-
m_executor->shutdown();
+ m_ccnx.reset ();
+
m_fetchList.clear_and_dispose (fetcher_disposer ());
}
@@ -101,7 +102,10 @@
Name forwardingHint;
forwardingHint = m_mapping (deviceName);
- m_taskDb->addTask(deviceName, baseName, minSeqNo, maxSeqNo, priority);
+ if (m_taskDb)
+ {
+ m_taskDb->addTask(deviceName, baseName, minSeqNo, maxSeqNo, priority);
+ }
unique_lock<mutex> lock (m_parellelFetchMutex);
@@ -221,7 +225,11 @@
m_currentParallelFetches --;
_LOG_TRACE ("+++++ removing fetcher: " << fetcher.GetName ());
m_fetchList.erase_and_dispose (FetchList::s_iterator_to (fetcher), fetcher_disposer ());
- m_taskDb->deleteTask(deviceName, baseName);
+
+ if (m_taskDb)
+ {
+ m_taskDb->deleteTask(deviceName, baseName);
+ }
}
m_scheduler->rescheduleTaskAt (m_scheduleFetchesTask, 0);