Changeset 3071 for source/ariba/overlay/BaseOverlay.cpp

Timestamp:

Apr 24, 2009, 4:34:53 PM (15 years ago)

Author:

Christoph Mayer

Message:

-some further fixed in the protocols and cleaning the interfaces for stuff we have no functionality yet

File:

• source/ariba/overlay/BaseOverlay.cpp (modified) (6 diffs)

source/ariba/overlay/BaseOverlay.cpp

@@ -98 +98 @@
 
         ovl.visShowNodeBubble ( ovlId, nodeId, "joining..." );
-        logging_info( "starting to join spovnet " << id.toString() << "...");
+        logging_info( "starting to join spovnet " << id.toString() <<
+                        " with nodeid " << nodeId.toString());
 
         //
@@ -145 +146 @@
         logging_debug( "leaving overlay" );
         // first, leave the overlay interface
-        overlayInterface->leaveOverlay();
+        if( overlayInterface != NULL )
+                overlayInterface->leaveOverlay();
 
         // --> leave spovnet
@@ -177 +179 @@
         //
 
-        logging_info("creating spovnet " + id.toString());
+        logging_info( "creating spovnet " + id.toString() << " with nodeid " << nodeId.toString() );
 
         spovnetId = id;
@@ -502 +504 @@
         if( i == linkMapping.end() ) return;
 
-        if( i->second.interface != NULL )
+        if( i->second.interface != NULL ){
                 i->second.interface->onLinkChanged( id, i->second.node );
+                // call onLinkQoSChanged?
+        }
 
         i->second.markused();
@@ -537 +541 @@
 
         // TODO: convert QoSParameterSet to the LinkProperties properties
-        if( i->second.interface != NULL )
-                i->second.interface->onLinkQoSChanged( id, i->second.node, LinkProperties::DEFAULT );
+        if( i->second.interface != NULL ){
+                // TODO: currently not in the interface: i->second.interface->onLinkQoSChanged( id, i->second.node, LinkProperties::DEFAULT );
+        }
 
         i->second.markused();
+}
+
+bool BaseOverlay::onLinkRequest( const LinkID& id, const NetworkLocator* local, const NetworkLocator* remote ){
+
+        // also see in the receiveMessage function. there the higher layer service
+        // is asked whether to accept link requests, but there a basic link association is
+        // already built up, so we know the node id
+        logging_debug("received link request from " << remote->toString() << ", accepting");
+        return true;
 }
 
@@ -791 +805 @@
 
                 i->second.interface = iface;
-                iface->onLinkUp( link, sourcenode );
                 i->second.markused();
 
-                return true ;
+                //
+                // ask the service whether it wants to accept this link
+                //
+
+                if( iface->onLinkRequest(sourcenode) ){
+                        iface->onLinkUp( link, sourcenode );
+                } else {
+                        // prevent onLinkDown calls to the service
+                        i->second.interface = NULL;
+                        // drop the link
+                        dropLink( link );
+                }
+
+                return true;
 
         } // else if( overlayMsg->isType(OverlayMsg::OverlayMessageTypeUpdate) )