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

Timestamp:

Apr 23, 2009, 7:18:10 PM (16 years ago)

Author:

Christoph Mayer

Message:

-fixes #4 (merge tidy interface with current implementation)

File:

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

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

@@ -58 +58 @@
 
 OneHop::~OneHop(){
-
         deleteOverlay();
 }
@@ -163 +162 @@
 }
 
-void OneHop::onLinkDown( const LinkID& link, const NodeID& local, const NodeID& remote ){
+
+void OneHop::onLinkDown(const LinkID& lnk, const NodeID& remote){
 
         //
@@ -175 +175 @@
 
         for( ; i != iend; i++ ){
-                if( i->second == link ){
+                if( i->second == lnk ){
                         overlayNodes.erase( i );
                         break;
@@ -182 +182 @@
 }
 
-void OneHop::onLinkUp(const LinkID& link, const NodeID& local, const NodeID& remote) {
+void OneHop::onLinkUp(const LinkID& lnk, const NodeID& remote){
 
         //
@@ -189 +189 @@
         //
 
-        if( link != bootstrapLink ){
+        if( lnk != bootstrapLink ){
                 if( pendingLinks > 0 )  pendingLinks--;
                 if( pendingLinks == 0 ) state = OneHopStateCompleted;
@@ -201 +201 @@
 
         state = OneHopStateJoinListingRequested;
-        baseoverlay.sendMessage( &onemsg, link );
-}
-
-bool OneHop::receiveMessage(const Message* message, const LinkID& link, const NodeID& node){
-
-        OneHopMessage* onemsg = const_cast<Message*>(message)->decapsulate<OneHopMessage>();
-        if( onemsg == NULL ) return false;
+        baseoverlay.sendMessage( &onemsg, lnk );
+}
+
+void OneHop::onMessage(const DataMessage& msg, const NodeID& remote, const LinkID& lnk){
+
+        OneHopMessage* onemsg = msg.getMessage()->convert<OneHopMessage>();
+        if( onemsg == NULL ) return;
 
         //
@@ -217 +217 @@
                 NodeListingRequest* request = onemsg->decapsulate<NodeListingRequest>();
 
-                logging_info( "onehop received node listing request from node " << node.toString() );
+                logging_info( "onehop received node listing request from node " << remote.toString() );
 
                 //
@@ -223 +223 @@
                 //
 
-                overlayNodes.insert( make_pair(node, link) );
+                overlayNodes.insert( make_pair(remote, lnk) );
 
                 //
@@ -249 +249 @@
 
                 onehopReply.encapsulate( &listingReply );
-                baseoverlay.sendMessage( &onehopReply, link );
+                baseoverlay.sendMessage( &onehopReply, lnk );
 
                 //
@@ -256 +256 @@
                 //
 
-                eventsReceiver->onNodeJoin( node );
+                eventsReceiver->onNodeJoin( remote );
 
         } // if( request != NULL )
@@ -268 +268 @@
                 NodeListingReply* reply = onemsg->decapsulate<NodeListingReply>();
 
-                logging_debug( "received node listing reply from node " << node.toString()
+                logging_debug( "received node listing reply from node " << remote.toString()
                                         << " with all overlay nodes. connecting to all of them" );