Changeset 3041 for source/ariba/overlay

Timestamp:

Apr 23, 2009, 9:18:12 AM (16 years ago)

Author:

Christoph Mayer

Message:

-mehrere Fixes, Tickets #25 (bind listeners earlier), #21 (better pingpong), #40 (systemqueue misbehavior)

Location:

source/ariba/overlay

Files:

• BaseOverlay.cpp (modified) (18 diffs)
• BaseOverlay.h (modified) (2 diffs)

source/ariba/overlay/BaseOverlay.cpp

@@ -47 +47 @@
 use_logging_cpp(BaseOverlay);
 
-BaseOverlay::BaseOverlay( BaseCommunication& _basecomm, const NodeID& _nodeid )
-        :       bc( _basecomm ), nodeId( _nodeid ), spovnetId( SpoVNetID::UNSPECIFIED), overlayInterface( NULL ),
-                initiatorLink( LinkID::UNSPECIFIED ), state( BaseOverlayStateInvalid ) {
+BaseOverlay::BaseOverlay()
+        : bc(NULL), overlayInterface(NULL),
+                nodeId(NodeID::UNSPECIFIED), spovnetId(SpoVNetID::UNSPECIFIED),
+                initiatorLink(LinkID::UNSPECIFIED), state(BaseOverlayStateInvalid){
+}
+
+BaseOverlay::~BaseOverlay(){
+}
+
+void BaseOverlay::start( BaseCommunication& _basecomm, const NodeID& _nodeid ){
+
+        bc = &_basecomm;
+        nodeId = _nodeid;
 
         logging_info("creating base overlay");
 
-        bc.registerMessageReceiver( this );
-        bc.registerEventListener( this );
+        bc->registerMessageReceiver( this );
+        bc->registerEventListener( this );
 
         ovl.visCreate( ovlId, nodeId, string(""), string("") );
@@ -75 +85 @@
 }
 
-BaseOverlay::~BaseOverlay() {
+void BaseOverlay::stop() {
 
         logging_info("deleting base overlay");
 
         Timer::stop();
-        bc.unregisterMessageReceiver( this );
-        bc.unregisterEventListener( this );
+        bc->unregisterMessageReceiver( this );
+        bc->unregisterEventListener( this );
 }
 
@@ -101 +111 @@
         state = BaseOverlayStateJoinInitiated;
 
-        initiatorLink = bc.establishLink( bootstrapEp );
+        initiatorLink = bc->establishLink( bootstrapEp );
+        logging_info("join process initiated for " << id.toString() << "...");
 }
 
@@ -124 +135 @@
                 // then, leave the spovnet baseoverlay
                 OverlayMsg overMsg( OverlayMsg::OverlayMessageTypeBye, nodeId );
-                bc.sendMessage( initiatorLink, &overMsg );
+                bc->sendMessage( initiatorLink, &overMsg );
 
                 // drop the link and set to correct state
-                bc.dropLink( initiatorLink );
+                bc->dropLink( initiatorLink );
                 initiatorLink = LinkID::UNSPECIFIED;
         }
@@ -175 +186 @@
 const EndpointDescriptor& BaseOverlay::getEndpointDescriptor(const LinkID& link) const {
 
-        return bc.getEndpointDescriptor( link );
+        return bc->getEndpointDescriptor( link );
 }
 
@@ -181 +192 @@
 
         if( node == nodeId || node == NodeID::UNSPECIFIED )
-                return bc.getEndpointDescriptor();
+                return bc->getEndpointDescriptor();
 
         if( overlayInterface == NULL ){
@@ -216 +227 @@
 
         ServiceInterface* receiver = listenerMux.get( service );
-        const LinkID link = bc.establishLink( ep );
+        const LinkID link = bc->establishLink( ep );
 
         LinkItem item (link, NodeID::UNSPECIFIED, service, receiver);
@@ -237 +248 @@
 
         LinkItem item = i->second;
-        bc.dropLink( link );
+        bc->dropLink( link );
 
         if( item.interface != NULL )
@@ -257 +268 @@
 
         i->second.markused();
-        return bc.sendMessage( link, &overmsg );
+        return bc->sendMessage( link, &overmsg );
 }
 
@@ -349 +360 @@
 
                 state = BaseOverlayStateJoinInitiated; // state remains in JoinInitiated
-                bc.sendMessage( id, &overMsg );
+                bc->sendMessage( id, &overMsg );
 
                 return;
@@ -384 +395 @@
                         );
 
-                bc.sendMessage( id, &overMsg );
+                bc->sendMessage( id, &overMsg );
                 i->second.markused();
 
@@ -555 +566 @@
 
                 retmsg.encapsulate(&replyMsg);
-                bc.sendMessage( link, &retmsg );
+                bc->sendMessage( link, &retmsg );
 
                 return true;
@@ -597 +608 @@
                 if( ! replyMsg->getJoinAllowed() ){
 
-                        logging_warn( "our join request has been denied" );
-
-                        bc.dropLink( initiatorLink );
+                        logging_error( "our join request has been denied" );
+
+                        bc->dropLink( initiatorLink );
                         initiatorLink = LinkID::UNSPECIFIED;
                         state = BaseOverlayStateInvalid;
@@ -624 +635 @@
                         logging_error( "overlay structure not supported" );
 
-                        bc.dropLink( initiatorLink );
+                        bc->dropLink( initiatorLink );
                         initiatorLink = LinkID::UNSPECIFIED;
                         state = BaseOverlayStateInvalid;
@@ -698 +709 @@
                 if( changed ){
                         OverlayMsg overMsg( OverlayMsg::OverlayMessageTypeUpdate, i->second.service, nodeId );
-                        bc.sendMessage( link, &overMsg );
+                        bc->sendMessage( link, &overMsg );
                 }
 
@@ -744 +755 @@
                 if( overlayMsg->getSourceNode() == spovnetInitiator ){
 
-                        bc.dropLink( initiatorLink );
+                        bc->dropLink( initiatorLink );
                         initiatorLink = LinkID::UNSPECIFIED;
                         state = BaseOverlayStateInvalid;
@@ -800 +811 @@
         for( ; i != iend; i++ ){
                 if( *i == nodeId) continue; // don't send to ourselfs
-                sendMessage( message, *i, service ); // TODO: sollte auto links aufbauen fÃŒr sowas
+                sendMessage( message, *i, service );
         }
 }
@@ -857 +868 @@
 void BaseOverlay::incomingRouteMessage(Message* msg){
         // gets handled as normal data message
-        // TODO: passt das so?
         receiveMessage( msg, LinkID::UNSPECIFIED, NodeID::UNSPECIFIED );
 }

source/ariba/overlay/BaseOverlay.h

@@ -126 +126 @@
 
         /**
-         * Constructs a Base Overlay instance
-         */
-        BaseOverlay( BaseCommunication& _basecomm, const NodeID& _nodeid );
-
-        /**
-         * TODO
+         * Constructs an empty non-functional base overlay instance
+         */
+        BaseOverlay();
+
+        /**
+         * Destructs a base overlay instance
          */
         virtual ~BaseOverlay();
+
+        /**
+         * Starts the Base Overlay instance
+         */
+        void start( BaseCommunication& _basecomm, const NodeID& _nodeid );
+
+        /**
+         * Stops the Base Overlay instance
+         */
+        void stop();
 
         /**
@@ -271 +281 @@
          * communicates over
          */
-        BaseCommunication& bc;
+        BaseCommunication* bc;
 
         /**