Changeset 3705 for source/ariba/overlay/modules/onehop/OneHop.cpp

Timestamp:

May 26, 2009, 4:27:55 PM (15 years ago)

Author:

Christoph Mayer

Message:

-einige fixed bzgl. link management, fehlerhafte serialisierer, etc.

File:

• source/ariba/overlay/modules/onehop/OneHop.cpp (modified) (6 diffs)

source/ariba/overlay/modules/onehop/OneHop.cpp

@@ -59 +59 @@
         //
         overlayNodes.insert( make_pair(_nodeid, LinkID::UNSPECIFIED) );
+
+        Timer::setInterval(5000);
+        Timer::start();
 }
 
 OneHop::~OneHop(){
+        Timer::stop();
         deleteOverlay();
 }
@@ -155 +159 @@
 
         //
-        // close all links, this will indicate the other nodes that we left
+        // send leave messages to all nodes. the nodes
+        // will then drop the links
         //
 
@@ -162 +167 @@
 
         for( ; i != iend; i++){
-                if( i->first != nodeid && i->second != LinkID::UNSPECIFIED )
-                        baseoverlay.dropLink( i->second );
+                if( i->first != nodeid && i->second != LinkID::UNSPECIFIED ){
+
+                        OneHopMessage msg (OneHopMessage::OneHopMessageTypeLeave);
+                        baseoverlay.sendMessage( &msg, i->second );
+                }
         }
 
@@ -177 +185 @@
 
         // node went down, remove from overlay mapping
-        logging_debug( "node " << remote.toString() << " left overlay structure" );
+        logging_debug( "link " << lnk.toString() << " to node " << remote.toString() << " went down, removing node" );
 
         OverlayNodeMapping::iterator i = overlayNodes.begin();
@@ -266 +274 @@
                 eventsReceiver->onNodeJoin( remote );
 
-        } // if( request != NULL )
+        } // OneHopMessageTypeListingRequest
 
         //
@@ -312 +320 @@
                 } // for( ; i != iend; i++ )
 
-        } // if( reply != NULL )
+        } // OneHopMessageTypeListingReply
+
+        //
+        // handle node leaves
+        //
+
+        if( onemsg->isType(OneHopMessage::OneHopMessageTypeLeave) ){
+
+                logging_debug("received leave message from " <<
+                                remote.toString() << " on link " << lnk.toString());
+
+                // drop the link to the node
+                baseoverlay.dropLink( lnk );
+
+        } // OneHopMessageTypeLeave
+
+        //
+        // handle kbr route messages
+        //
 
         if( onemsg->isType( OneHopMessage::OneHopMessageTypeRoute) ){
                 logging_debug( "Route message arrived at destination node -> delegate to BaseOverlay" );
                 baseoverlay.incomingRouteMessage( onemsg );
-        }
-
+        } // OneHopMessageTypeRoute
+
+}
+
+void OneHop::eventFunction(){
+
+        logging_debug("<<<<<<<<<<<<<<<<onehop-table<<<<<<<<<<<<<<<<<<<");
+
+                OverlayNodeMapping::iterator i = overlayNodes.begin();
+                OverlayNodeMapping::iterator iend = overlayNodes.end();
+
+                for( ; i != iend; i++ ){
+
+                        const NodeID node = i->first;
+                        const LinkID link = i->second;
+                        const EndpointDescriptor& endpoint = baseoverlay.getEndpointDescriptor( link );
+
+                        logging_debug(  "node: " << node.toString() <<
+                                                        ", link_: " << link.toString() << ", endp: " << endpoint.toString());
+                }
+
+        logging_debug(">>>>>>>>>>>>>>>>>onehop-table>>>>>>>>>>>>>>>>>>>>>");
 
 }