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

Timestamp:

May 7, 2009, 4:51:31 PM (15 years ago)

Author:

Christoph Mayer

Message:

-Integration of Branch 20090424-mayer-sideport

File:

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

source/ariba/overlay/BaseOverlay.cpp

@@ -42 +42 @@
 #include "ariba/NodeListener.h"
 #include "ariba/CommunicationListener.h"
+#include "ariba/SideportListener.h"
 
 namespace ariba {
@@ -49 +50 @@
 
 BaseOverlay::BaseOverlay()
-        : bc(NULL), overlayInterface(NULL),
-                nodeId(NodeID::UNSPECIFIED), spovnetId(SpoVNetID::UNSPECIFIED),
-                initiatorLink(LinkID::UNSPECIFIED), state(BaseOverlayStateInvalid){
+        : bc(NULL), overlayInterface(NULL), nodeId(NodeID::UNSPECIFIED),
+                spovnetId(SpoVNetID::UNSPECIFIED), initiatorLink(LinkID::UNSPECIFIED),
+                state(BaseOverlayStateInvalid), sideport(&SideportListener::DEFAULT){
 }
 
@@ -230 +231 @@
 
         CommunicationListener* receiver = communicationListeners.get( service );
+        assert( receiver != NULL );
+
         LinkItem item (link, NodeID::UNSPECIFIED, service, receiver);
         linkMapping.insert( make_pair(link, item) );
@@ -251 +254 @@
         bc->dropLink( link );
 
-        if( item.interface != NULL )
-                item.interface->onLinkDown( link, item.node );
+        item.interface->onLinkDown( link, item.node );
+        sideport->onLinkDown(link, this->nodeId, item.node, this->spovnetId );
 }
 
@@ -352 +355 @@
         communicationListeners.registerItem( listener, sid );
         return true;
+}
+
+bool BaseOverlay::registerSidePort(SideportListener* _sideport){
+        sideport = _sideport;
+        _sideport->configure( this );
+}
+
+bool BaseOverlay::unregisterSidePort(SideportListener* _sideport){
+        sideport = &SideportListener::DEFAULT;
 }
 
@@ -442 +454 @@
         if( i == linkMapping.end() ){
 
-                LinkItem item (id, NodeID::UNSPECIFIED, ServiceID::UNSPECIFIED, NULL );
+                LinkItem item (id, NodeID::UNSPECIFIED, ServiceID::UNSPECIFIED, &CommunicationListener::DEFAULT );
                 linkMapping.insert( make_pair(id, item) );
 
@@ -487 +499 @@
         }
 
-        if( i->second.interface != NULL )
-                i->second.interface->onLinkDown( id, i->second.node );
+        i->second.interface->onLinkDown( id, i->second.node );
+        sideport->onLinkDown( id, this->nodeId, i->second.node, this->spovnetId );
 
         linkMapping.erase( i );
@@ -504 +516 @@
         if( i == linkMapping.end() ) return;
 
-        if( i->second.interface != NULL ){
-                i->second.interface->onLinkChanged( id, i->second.node );
-                // call onLinkQoSChanged?
-        }
+        i->second.interface->onLinkChanged( id, i->second.node );
+        sideport->onLinkChanged( id, this->nodeId, i->second.node, this->spovnetId );
+
+        // TODO call onLinkQoSChanged?
 
         i->second.markused();
@@ -523 +535 @@
         if( i == linkMapping.end() ) return;
 
-        if( i->second.interface != NULL )
-                i->second.interface->onLinkFail( id, i->second.node );
+        i->second.interface->onLinkFail( id, i->second.node );
+        sideport->onLinkFail( id, this->nodeId, i->second.node, this->spovnetId );
 
         i->second.markused();
@@ -541 +553 @@
 
         // TODO: convert QoSParameterSet to the LinkProperties properties
-        if( i->second.interface != NULL ){
-                // TODO: currently not in the interface: i->second.interface->onLinkQoSChanged( id, i->second.node, LinkProperties::DEFAULT );
-        }
+        // TODO: currently not in the interface: i->second.interface->onLinkQoSChanged( id, i->second.node, LinkProperties::DEFAULT );
 
         i->second.markused();
@@ -799 +809 @@
 
                 CommunicationListener* iface = communicationListeners.get( service );
-                if( iface == NULL ){
+                if( iface == NULL || iface == &CommunicationListener::DEFAULT ){
                         logging_warn( "linkup event for service that has been registered with a NULL interface" );
                         return true;
@@ -812 +822 @@
 
                 if( iface->onLinkRequest(sourcenode) ){
+
+                        // call the notification functions
                         iface->onLinkUp( link, sourcenode );
+                        sideport->onLinkUp( link, nodeId, sourcenode, this->spovnetId );
+
                 } else {
                         // prevent onLinkDown calls to the service
-                        i->second.interface = NULL;
+                        i->second.interface = &CommunicationListener::DEFAULT;
                         // drop the link
                         dropLink( link );
@@ -950 +964 @@
 }
 
+vector<LinkID> BaseOverlay::getLinkIDs( const NodeID& nid ) const {
+
+        vector<LinkID> linkvector;
+
+        BOOST_FOREACH( LinkPair item, linkMapping ){
+                if( item.second.node == nid || nid == NodeID::UNSPECIFIED ){
+                        linkvector.push_back( item.second.link );
+                }
+        }
+
+        return linkvector;
+}
+
 void BaseOverlay::incomingRouteMessage(Message* msg){
         // gets handled as normal data message