commit a12f528b5274e018c09326d8a0b4b21528f34c3c
author Shuo Chen <chenatu2006@gmail.com> Fri Aug 01 15:18:30 2014 +0800
committer Alex Afanasyev <alexander.afanasyev@ucla.edu> Wed Aug 13 18:49:03 2014 -0700
tree fa82759fa48582043d7e6e473da307e66a92216f
parent 90d1e88e0d25ea5c19a811091e255d43c6f150ad

repo: initialize storage (e.g., rebuild index)

Change-Id: Iba8d5db1ecfb67c085f7f6355726a41b3f48aafa
Refs: #1831

src/main.cpp

diff --git a/src/main.cpp b/src/main.cpp
index 999b7b8..3a1be07 100644
--- a/src/main.cpp
+++ b/src/main.cpp
@@ -82,6 +82,8 @@
     signalSet.async_wait(bind(&terminate, boost::ref(ioService), _1, _2,
                               boost::ref(signalSet)));
 
+    repoInstance.initializeStorage();
+
     repoInstance.enableValidation();
 
     repoInstance.enableListening();

src/repo.cpp

diff --git a/src/repo.cpp b/src/repo.cpp
index 346fa23..02c80da 100644
--- a/src/repo.cpp
+++ b/src/repo.cpp
@@ -128,6 +128,17 @@
 }
 
 void
+Repo::initializeStorage()
+{
+  // Rebuild storage if storage checkpoin exists
+  ndn::time::steady_clock::TimePoint start = ndn::time::steady_clock::now();
+  m_storageHandle.initialize();
+  ndn::time::steady_clock::TimePoint end = ndn::time::steady_clock::now();
+  ndn::time::milliseconds cost = ndn::time::duration_cast<ndn::time::milliseconds>(end - start);
+  std::cerr << "initialize storage cost: " << cost << "ms" << std::endl;
+}
+
+void
 Repo::enableListening()
 {
   // Enable "listening" on Data prefixes

src/repo.hpp

diff --git a/src/repo.hpp b/src/repo.hpp
index ba518d1..e1feea6 100644
--- a/src/repo.hpp
+++ b/src/repo.hpp
@@ -72,6 +72,10 @@
 public:
   Repo(boost::asio::io_service& ioService, const RepoConfig& config);
 
+  //@brief rebuild index from storage file when repo starts.
+  void
+  initializeStorage();
+
   void
   enableListening();