Changeset 5803 for source/ariba/overlay/modules/chord/Chord.cpp

Timestamp:

Aug 10, 2009, 5:55:19 PM (15 years ago)

Author:

huebsch

Message:

revert des kompletten overlay ordners auf revision 5752

File:

• source/ariba/overlay/modules/chord/Chord.cpp (modified) (14 diffs)

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

@@ -58 +58 @@
         // create routing table
         this->table = new chord_routing_table(_nodeid, 2);
-
-        // init counters
         orphan_removal_counter = 0;
         discovery_count = 0;
@@ -92 +90 @@
 
         // establish link via base overlay
-        return baseoverlay.establishLink(endp, node, OverlayInterface::OVERLAY_SERVICE_ID,
-                        remoteRelay );
+        return baseoverlay.establishLink(endp, node, OverlayInterface::OVERLAY_SERVICE_ID, remoteRelay );
 }
 
@@ -100 +97 @@
         if (link.isUnspecified()) return 0;
         return baseoverlay.sendMessage(msg, link);
-}
-
-const LinkID& Chord::get_next_hop( const NodeID& id ) const {
-        BOOST_FOREACH( const back_route& br, back_routes )
-                if (br.id==id) return br.link;
-        const route_item* item = table->get_next_hop(id);
-        if (item==NULL) return LinkID::UNSPECIFIED;
-        return item->info;
 }
 
@@ -123 +112 @@
 
         // get next hop
-        LinkID next_link = get_next_hop(destination);
-        if (!next_link.isUnspecified()) send(&cmsg, next_link);
+        const route_item* item = table->get_next_hop(destination);
+        if (item!=NULL && !item->info.isUnspecified()) send(&cmsg, item->info);
 }
 
@@ -190 +179 @@
 void Chord::routeMessage(const NodeID& destnode, Message* msg) {
         // get next hop
-        LinkID next_link = get_next_hop(destnode);
+        const route_item* item = table->get_next_hop(destnode);
 
         // message for this node? yes-> delegate to base overlay
-        if (destnode == nodeid)
+        if (item->id == nodeid || destnode == nodeid)
                 baseoverlay.incomingRouteMessage( msg, LinkID::UNSPECIFIED, nodeid );
 
@@ -199 +188 @@
                 ChordMessage cmsg(ChordMessage::route, nodeid, destnode);
                 cmsg.encapsulate(msg);
-                send(&cmsg, next_link);
+                send(&cmsg, item->info);
         }
 }
@@ -214 +203 @@
 /// @see OverlayInterface.h
 const LinkID& Chord::getNextLinkId( const NodeID& id ) const {
-        return get_next_hop(id);
+        // get next hop
+        const route_item* item = table->get_next_hop(id);
+
+        // returns a unspecified id when this is itself
+        if (item == NULL || item->id == nodeid)
+                return LinkID::UNSPECIFIED;
+
+        /// return routing info
+        return item->info;
 }
 
@@ -223 +220 @@
                 // all nodes that I know, fingers, succ/pred
                 for (size_t i = 0; i < table->size(); i++){
-                        if (/*(*table)[i]->ref_count != 0
-                                        &&*/ !(*table)[i]->info.isUnspecified())
+                        if ((*table)[i]->ref_count != 0
+                                        && !(*table)[i]->info.isUnspecified())
                                 nodelist.push_back((*table)[i]->id);
                 }
@@ -309 +306 @@
         case M::route: {
                 // find next hop
-                LinkID next_link = get_next_hop(m->getDestination());
-
-                // add to back-routes
-                bool found = false;
-                BOOST_FOREACH( back_route br, back_routes) {
-                        if (br.id == m->getSource()) {
-                                br.link = link;
-                                br.lastseen = time(NULL);
-                                found = true;
-                                break;
-                        }
-                }
-                if (!found) {
-                        back_route br;
-                        br.id = m->getSource();
-                        br.link = link;
-                        br.lastseen = time(NULL);
-                        back_routes.push_back(br);
-                }
+                const route_item* item = table->get_next_hop(m->getDestination());
 
                 // next hop == myself?
                 if (m->getDestination() == nodeid) { // yes-> route to base overlay
                         logging_debug("Send message to baseoverlay");
-                        baseoverlay.incomingRouteMessage( m, next_link, remote );
+                        baseoverlay.incomingRouteMessage( m, item->info, remote );
                 }
                 // no-> route to next hop
                 else {
-//                      logging_debug("Route chord message to "
-//                              << item->id.toString() << " (destination=" << m->getDestination() << ")");
-                        send(m, next_link);
+                        logging_debug("Route chord message to "
+                                << item->id.toString() << " (destination=" << m->getDestination() << ")");
+                        send(m, item->info);
                 }
                 break;
@@ -378 +357 @@
                                         logging_debug("Discovery split: routing discovery message to successor "
                                                         << succ_item->id.toString() );
-                                        cmsg_s.setDestination(succ_item->id);
                                         send(&cmsg_s, succ_item->info);
                                 }
@@ -392 +370 @@
                                         logging_debug("Discovery split: routing discovery message to predecessor "
                                                         << pred_item->id.toString() );
-                                        cmsg_p.setDestination(pred_item->id);
                                         send(&cmsg_p, pred_item->info);
                                 }
@@ -399 +376 @@
                         else {
                                 // find next hop
-                                LinkID next_link = get_next_hop(m->getDestination());
-                        //      logging_debug("routing discovery message to " <<
-                        //                      linkitem->id.toString() );
-                                send(m, next_link);
+                                const route_item* item = table->get_next_hop(m->getDestination());
+                                if (item == NULL || item->id == nodeid) break;
+                                logging_debug("routing discovery message to " <<
+                                                item->id.toString() );
+                                send(m, item->info);
                         }
                         break;
@@ -453 +431 @@
 void Chord::eventFunction() {
         stabilize_counter++;
-        if (stabilize_counter < 0 || stabilize_counter >= 2) {
+        if (stabilize_counter < 0 || stabilize_counter == 4) {
 
                 // reset counter
@@ -487 +465 @@
                 orphan_removal_counter++;
                 if (orphan_removal_counter <0 || orphan_removal_counter >= 4) {
-                        back_routes.clear();
-/*                      for (vector<back_route>::iterator i = back_routes.begin();
-                                        i!=back_routes.end(); i++) {
-                                back_route& br = *i;
-                                if (difftime(br.lastseen,time(NULL))>5) i =
-                                                back_routes.erase(i)-1;
-                        }
-*/
                         logging_info("Running orphan removal");
                         orphan_removal_counter = 0;