Changeset 5876 for source/ariba/overlay/modules/chord

Timestamp:

Aug 12, 2009, 12:04:09 AM (15 years ago)

Author:

mies

Message:

 

Location:

source/ariba/overlay/modules/chord

Files:

• Chord.cpp (modified) (6 diffs)
• Chord.h (modified) (1 diff)

source/ariba/overlay/modules/chord/Chord.cpp

@@ -232 +232 @@
                         break;
                 }
-/*
-        // check if we already have a connection, yes-> do not handle duplicate!
-        for (int i=0; i<table->size(); i++)
-                if ((*table)[i]->id == remote && !((*table)[i]->info.isUnspecified()) && (*table)[i]->info != lnk) {
-
-                        return;
-                }
-*/
+
         if (remote==nodeid) {
                 baseoverlay.dropLink(lnk);
@@ -305 +298 @@
                 );
 
+                // add discovery node id
+                bool found = false;
+                BOOST_FOREACH( NodeID& value, discovery )
+                        if (value == m->getSourceNode()) {
+                                found = true;
+                                break;
+                        }
+                if (!found) discovery.push_back(m->getSourceNode());
+
                 // check if source node can be added to routing table and setup link
-                if (m->getSourceNode() != nodeid
-                        && table->is_insertable(m->getSourceNode()))
+                if (m->getSourceNode() != nodeid)
                         setup( dmsg->getEndpoint(), m->getSourceNode() );
 
@@ -317 +318 @@
                         // closest node? yes-> split to follow successor and predecessor
                         if ( table->is_closest_to(m->getDestinationNode()) ) {
-
-                                if (table->get_successor() != NULL) {
+                                logging_debug("Discovery split:");
+                                if (!table->get_successor()->isUnspecified()) {
                                         OverlayMsg omsg(*m);
                                         dmsg->setType(Discovery::successor);
                                         omsg.encapsulate(dmsg);
-                                        route_item* succ_item = table->get(*table->get_successor());
-                                        logging_debug("Discovery split: routing discovery message to successor "
-                                                        << succ_item->id.toString() );
-                                        send(&omsg, succ_item->info);
+                                        logging_debug("* Routing to successor "
+                                                        << table->get_successor()->toString() );
+                                        baseoverlay.send( &omsg, *table->get_successor() );
                                 }
 
                                 // send predecessor message
-                                if (table->get_predesessor() != NULL) {
+                                if (!table->get_predesessor()->isUnspecified()) {
                                         OverlayMsg omsg(*m);
                                         dmsg->setType(Discovery::predecessor);
                                         omsg.encapsulate(dmsg);
-                                        route_item* pred_item = table->get(
-                                                        *table->get_predesessor());
-                                        logging_debug("Discovery split: routing discovery message to predecessor "
-                                                        << pred_item->id.toString() );
-                                        send( &omsg, pred_item->info);
+                                        logging_debug("* Routing to predecessor "
+                                                        << table->get_predesessor()->toString() );
+                                        baseoverlay.send( &omsg, *table->get_predesessor() );
                                 }
                         }
@@ -365 +363 @@
                         }
                         if (item == NULL) break;
-                        logging_debug("routing discovery message to succ/pred "
+                        logging_debug("Routing discovery message to succ/pred "
                                 << item->id.toString() );
                         OverlayMsg omsg(*m);
                         omsg.encapsulate(dmsg);
                         omsg.setDestinationNode(item->id);
+                        omsg.setService(OverlayInterface::OVERLAY_SERVICE_ID);
+                        omsg.setRelayed(true);
                         baseoverlay.send(&omsg, omsg.getDestinationNode());
                         break;
@@ -407 +407 @@
                 logging_info("Running stabilization: #links="
                                 << table->size() << " #neighbors=" << numNeighbors );
+
+                // updating neighbors
+                for (int i=0; i<table->size(); i++) {
+                        LinkID id = (*table)[i]->info;
+                        if (!id.isUnspecified()) discover_neighbors(id);
+                }
 
                 // sending discovery
@@ -417 +423 @@
                         send_discovery_to(disc2);
 
-                for (int i=0; i<table->size(); i++) {
-                        LinkID id = (*table)[i]->info;
-                        if (!id.isUnspecified()) discover_neighbors(id);
-                }
 
                 // remove orphan links
                 orphan_removal_counter++;
                 if (orphan_removal_counter <0 || orphan_removal_counter >= 2) {
+                        logging_info("Discovered nodes: ");
+                        BOOST_FOREACH( NodeID& id, discovery )
+                                logging_info("* " << id.toString());
+                        discovery.clear();
                         logging_info("Running orphan removal");
                         orphan_removal_counter = 0;

source/ariba/overlay/modules/chord/Chord.h

@@ -80 +80 @@
         vector<LinkID> bootstrapLinks;
         vector<NodeID> pending;
+        vector<NodeID> discovery;
         int discovery_count;