commit 44e4fd95fd5a2d8280183f6f79c540b91fcdca66
author Mickey Sweatt <mickeysweatt@engineering.ucla.edu> Mon May 02 15:43:11 2016 -0700
committer Mickey Sweatt <mickeysweatt@engineering.ucla.edu> Tue May 03 14:06:05 2016 -0700
tree 6db975d149c6e3f7dcd8b931eeb3206cab4fbe1a
parent 15dde2d734e4e6436bce7cd45cf00e11e70e0374

Implemented set to monitor pending interests in manager.

Change-Id: I4a11db79053e69a19ceba0e0501b93911131d1d7

src/sequential-data-fetcher.cpp

diff --git a/src/sequential-data-fetcher.cpp b/src/sequential-data-fetcher.cpp
index 9a5ae5f..472cd71 100644
--- a/src/sequential-data-fetcher.cpp
+++ b/src/sequential-data-fetcher.cpp
@@ -26,12 +26,14 @@
 namespace ndn {
 namespace ntorrent {
 
-SequentialDataFetcher::SequentialDataFetcher(const ndn::Name& torrentFileName,
-                                             const std::string& dataPath)
+SequentialDataFetcher::SequentialDataFetcher(const ndn::Name&   torrentFileName,
+                                             const std::string& dataPath,
+                                             bool               seed)
   : m_dataPath(dataPath)
   , m_torrentFileName(torrentFileName)
+  , m_seedFlag(seed)
 {
-  m_manager = make_shared<TorrentManager>(m_torrentFileName, m_dataPath);
+  m_manager = make_shared<TorrentManager>(m_torrentFileName, m_dataPath, seed);
 }
 
 SequentialDataFetcher::~SequentialDataFetcher()
@@ -121,6 +123,9 @@
       }
       else {
         LOG_INFO << "All data complete" <<  std::endl;
+        if (!m_seedFlag) {
+          m_manager->shutdown();
+        }
       }
     }
   }
@@ -136,6 +141,8 @@
 void
 SequentialDataFetcher::onTorrentFileSegmentReceived(const std::vector<Name>& manifestNames)
 {
+  // TODO(msweatt) Add parameter for torrent file
+  LOG_INFO << "Torrent Segment Received: " << m_torrentFileName << std::endl;
   this->downloadManifestFiles(manifestNames);
 }