commit 71bc0ba8a96dba9b436be3ad922fa15b154b699d
author Zhenkai Zhu <zhenkai@cs.ucla.edu> Fri Oct 05 14:37:44 2012 -0700
committer Zhenkai Zhu <zhenkai@cs.ucla.edu> Fri Oct 05 14:37:44 2012 -0700
tree 3d59b553e10d455888d65065aec9a166b1524d87
parent 26cd6e34fd003207730935d4d45acf009be6c89b

reset interest filter

ccnx/sync-ccnx-wrapper.cc

diff --git a/ccnx/sync-ccnx-wrapper.cc b/ccnx/sync-ccnx-wrapper.cc
index bc1ea0f..d0a6376 100644
--- a/ccnx/sync-ccnx-wrapper.cc
+++ b/ccnx/sync-ccnx-wrapper.cc
@@ -59,19 +59,21 @@
 void
 CcnxWrapper::connectCcnd()
 {
-  /*
-  if (m_handle != NULL)
-  {
-    ccn_destroy(&m_handle);
-  }
-  */
+  ccn_disconnect (m_handle);
   _LOG_DEBUG("<<< connecting to ccnd");
   if (ccn_connect(m_handle, NULL) < 0)
   {
-    //ccn_destroy(&m_handle);
     _LOG_DEBUG("<<< connecting to ccnd failed");
     BOOST_THROW_EXCEPTION (CcnxOperationException() << errmsg_info_str("connection to ccnd failed"));
   }
+  if (!m_registeredInterests.empty())
+  {
+    for (map<std::string, InterestCallback>::const_iterator it = m_registeredInterests.begin(); it != m_registeredInterests.end(); ++it)
+    {
+      setInterestFilter(it->first, it->second);
+      _LOG_DEBUG("<<< registering interest filter for: " << it->first);
+    }
+  }
 }
 
 CcnxWrapper::~CcnxWrapper()
@@ -283,6 +285,7 @@
       interest += compStr;
     }
   (*f) (interest);
+  _LOG_DEBUG("<<< processed interest: " << interest);
   return CCN_UPCALL_RESULT_OK;
 }
 
@@ -372,6 +375,8 @@
     _LOG_ERROR("<<< Express interest failed: " << strInterest);
   }
 
+  _LOG_DEBUG("<<< Sending interest: " << strInterest);
+
   ccn_charbuf_destroy (&pname);
   return 0;
 }
@@ -394,6 +399,7 @@
       BOOST_THROW_EXCEPTION(CcnxOperationException() << errmsg_info_str("set interest filter failed") << errmsg_info_int (ret));
     }
 
+  m_registeredInterests.insert(pair<std::string, InterestCallback>(prefix, interestCallback));
   ccn_charbuf_destroy(&pname);
 }
 
@@ -414,6 +420,7 @@
       BOOST_THROW_EXCEPTION(CcnxOperationException() << errmsg_info_str("set interest filter failed") << errmsg_info_int (ret));
     }
 
+  m_registeredInterests.erase(prefix);
   ccn_charbuf_destroy(&pname);
 }