commit 3f64d2ddc511da32c2acb9fe852e77a177c59dfc
author Zhenkai Zhu <zhenkai@cs.ucla.edu> Fri Jan 25 14:34:59 2013 -0800
committer Zhenkai Zhu <zhenkai@cs.ucla.edu> Fri Jan 25 14:34:59 2013 -0800
tree 877d189e6ee534bde11c0b5d4c01c65028fcb13e
parent cbbb88860cbac60f26daf6a0937b6b91a50ea826

fix bug in dispatcher about registering prefixes
unify broadcast domain in fetch-manager

src/dispatcher.cc

diff --git a/src/dispatcher.cc b/src/dispatcher.cc
index 6635c12..a4000d8 100644
--- a/src/dispatcher.cc
+++ b/src/dispatcher.cc
@@ -59,7 +59,7 @@
 
   m_server = new ContentServer(m_ccnx, m_actionLog, rootDir, m_localUserName, m_sharedFolder);
   m_server->registerPrefix(Name ("/"));
-  m_server->registerPrefix(syncPrefix);
+  m_server->registerPrefix(Name(BROADCAST_DOMAIN));
 
   m_core = new SyncCore (m_syncLog, localUserName, Name ("/"), syncPrefix,
                          bind(&Dispatcher::Did_SyncLog_StateChange, this, _1), ccnx);
@@ -69,7 +69,9 @@
 
   if (m_enablePrefixDiscovery)
   {
-    Ccnx::CcnxDiscovery::registerCallback (TaggedFunction (bind (&Dispatcher::Did_LocalPrefix_Updated, this, _1), "dispatcher"));
+    _LOG_DEBUG("registering prefix discovery in Dispatcher");
+    string tag = "dispatcher" + m_localUserName.toString();
+    Ccnx::CcnxDiscovery::registerCallback (TaggedFunction (bind (&Dispatcher::Did_LocalPrefix_Updated, this, _1), tag));
   }
 
   m_executor.start ();
@@ -84,7 +86,9 @@
 
   if (m_enablePrefixDiscovery)
   {
-    Ccnx::CcnxDiscovery::deregisterCallback (TaggedFunction (bind (&Dispatcher::Did_LocalPrefix_Updated, this, _1), "dispatcher"));
+    _LOG_DEBUG("deregistering prefix discovery in Dispatcher");
+    string tag = "dispatcher" + m_localUserName.toString();
+    Ccnx::CcnxDiscovery::deregisterCallback (TaggedFunction (bind (&Dispatcher::Did_LocalPrefix_Updated, this, _1), tag));
   }
 
   if (m_core != NULL)
@@ -106,7 +110,7 @@
   Name oldLocalPrefix = m_syncLog->LookupLocalLocator ();
   _LOG_DEBUG ("LocalPrefix changed from: " << oldLocalPrefix << " to: " << prefix);
 
-  m_server->deregisterPrefix(prefix);
+  m_server->registerPrefix(prefix);
   m_syncLog->UpdateLocalLocator (prefix);
   m_server->deregisterPrefix(oldLocalPrefix);
 }