commit 387ac9522107eae4b4dd0fbb709fb497847a305a
author Alexander Afanasyev <alexander.afanasyev@ucla.edu> Sun Mar 11 23:49:27 2012 -0700
committer Alexander Afanasyev <alexander.afanasyev@ucla.edu> Sun Mar 11 23:49:27 2012 -0700
tree d3a68c6c062369a5d92aa522157e7448cc472d25
parent a022f3d918f1ecbd139981020b19797f114f8710

Correcting SyncLogic with respect of delayed response to unrecognized digests

test/test_interest_table.cc

diff --git a/test/test_interest_table.cc b/test/test_interest_table.cc
index 4d9a29d..7cca0eb 100644
--- a/test/test_interest_table.cc
+++ b/test/test_interest_table.cc
@@ -28,8 +28,7 @@
 #include <boost/make_shared.hpp>
 
 #include "../model/sync-interest-table.h"
-#include "../model/sync-app-data-fetch.h"
-#include "../model/sync-app-data-publish.h"
+#include "../model/sync-logic.h"
 
 using namespace Sync;
 using namespace std;
@@ -43,3 +42,44 @@
   BOOST_CHECK_NO_THROW (delete table);
 }
 
+void func (const std::string &, uint32_t, uint32_t)
+{
+  cout << "func\n";
+}
+
+BOOST_AUTO_TEST_CASE (SyncLogicTest)
+{  
+  SyncLogic *logic = 0;
+  BOOST_CHECK_NO_THROW (logic = new SyncLogic ("/prefix", func, make_shared<CcnxWrapper> ()));
+  BOOST_CHECK_EQUAL (logic->getListChecksSize (), 0);
+
+  // 0s
+  BOOST_CHECK_NO_THROW (logic->respondSyncInterest ("/prefix/e5fa44f2b31c1fb553b6021e7360d07d5d91ff5e")); 
+  sleep (1);
+
+  // 1s
+  BOOST_CHECK_NO_THROW (logic->respondSyncInterest ("/prefix/e5fa44f2b31c1fb553b6021e7360d07d5d91ff5e")); 
+  sleep (1);
+
+  // 2s
+  // cout << "Wait queue size: " << logic->getListChecksSize () << endl;
+  BOOST_CHECK_EQUAL (logic->getListChecksSize (), 1);
+
+  // 2s
+  BOOST_CHECK_NO_THROW (logic->respondSyncInterest ("/prefix/e5fa44f2b31c1fb553b6021e7360d07d5d91ff5e"));  
+  // cout << "Wait queue size: " << logic->getListChecksSize () << endl;
+  BOOST_CHECK_EQUAL (logic->getListChecksSize (), 2);
+
+  this_thread::sleep (posix_time::milliseconds (2500)); // make two interests expire
+
+  // 4.5s
+  // cout << "(after 3.3s) Wait queue size: " << logic->getListChecksSize () << endl;
+  BOOST_CHECK_EQUAL (logic->getListChecksSize (), 1);
+
+  BOOST_CHECK_NO_THROW (logic->respondSyncInterest ("/prefix/e5fa44f2b31c1fb553b6021e7360d07d5d91ff5e"));
+  sleep (5);
+  BOOST_CHECK_EQUAL (logic->getListChecksSize (), 0);
+  
+  BOOST_CHECK_NO_THROW (delete logic);
+}
+