Changeset 12438 for source/ariba/overlay

Timestamp:

Oct 2, 2013, 12:01:09 PM (11 years ago)

Author:

hock@…

Message:

new callbacks in ariba::NodeListener:

• onOverlayConnected
• onOverlayDisconnected

Location:

source/ariba/overlay

Files:

• BaseOverlay.cpp (modified) (4 diffs)
• BaseOverlay.h (modified) (1 diff)

source/ariba/overlay/BaseOverlay.cpp

@@ -795 +795 @@
 
 BaseOverlay::BaseOverlay() :
-                        started(false),state(BaseOverlayStateInvalid),
+                        started(false),
+                        connected(false),
+                        state(BaseOverlayStateInvalid),
                         bc(NULL),
                         nodeId(NodeID::UNSPECIFIED), spovnetId(SpoVNetID::UNSPECIFIED),
@@ -1245 +1247 @@
         }
         
-        // TODO AKTUELL: sequence numbers
+        // TODO XXX ----> coordinate with QUIC-efforts !!
+        // TODO aktuell: sequence numbers
         // TODO seqnum on fast path ?
         ld->last_sent_seqnum.increment();
@@ -1620 +1623 @@
         // erase mapping
         eraseDescriptor(ld->overlayId);
+    
+    
+    // notify the application if this is the last link to a different node
+    if ( connected )
+    {
+        bool active_links = false;
+        
+        // look for links that are still active
+        foreach( LinkDescriptor* ld, links )
+        {
+            if ( isLinkDirectVital(ld) )
+            {
+                active_links = true;
+                break;
+            }
+        }
+
+        if ( ! active_links )
+        {
+            connected = false;
+            
+            foreach( NodeListener* i, nodeListeners )
+                i->onOverlayDisconnected( spovnetId );
+        }
+    }
+
 }
 
@@ -2093 +2122 @@
         sideport->onLinkUp( ld->overlayId, nodeId, ld->remoteNode, this->spovnetId );
 
+    
+    // notify the application if this is the first link to a different node
+    if ( not connected )
+    {
+        connected = true;
+        
+        foreach( NodeListener* i, nodeListeners )
+            i->onOverlayConnected( spovnetId );
+    }
+    
         return true;
 }

source/ariba/overlay/BaseOverlay.h

@@ -425 +425 @@
         /// is the base overlay started yet
         bool started;
+    
+    /// »true« if we have neighbours, »false« otherwise
+    bool connected;
 
         /// The state of the BaseOverlay