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

Timestamp:

Mar 11, 2010, 9:28:24 AM (14 years ago)

Author:

Christoph Mayer

Message:

-branch merge back

File:

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

source/ariba/overlay/BaseOverlay.cpp

@@ -135 +135 @@
                 for (vector<ValueEntry>::iterator i = values.begin();
                                 i != values.end(); i++ )
-                        if (i->is_ttl_elapsed()) i = values.erase(i);
+                        if (i->is_ttl_elapsed()) i = values.erase(i)-1;
         }
 };
@@ -214 +214 @@
                         // found? yes-> delete entry
                         if ( equals(entry.key, key) ) {
-                                i = entries.erase(i);
+                                i = entries.erase(i)-1;
                                 return true;
                         }
@@ -233 +233 @@
                                         // value found? yes-> delete
                                         if (equals(j->get_value(), value)) {
-                                                j = entry.values.erase(j);
+                                                j = entry.values.erase(j)-1;
                                                 return true;
                                         }
@@ -252 +252 @@
                                 // value found? yes-> delete
                                 if (j->is_ttl_elapsed())
-                                        j = entry.values.erase(j);
+                                        j = entry.values.erase(j)-1;
                         }
 
-                        if (entry.values.size()==0) i = entries.erase(i);
+                        if (entry.values.size()==0) i = entries.erase(i)-1;
                 }
         }
@@ -1911 +1911 @@
                         "in the overlay from service " + service.toString() );
 
+        if(message == NULL) return;
+        message->setReleasePayload(false);
+
         OverlayInterface::NodeList nodes = overlayInterface->getKnownNodes(true);
-        OverlayInterface::NodeList::iterator i = nodes.begin();
-        for(; i != nodes.end(); i++ ) {
-                if( *i == nodeId) continue; // don't send to ourselfs
-                sendMessage( message, *i, service );
+        for(size_t i=0; i<nodes.size(); i++){
+                NodeID& id = nodes.at(i);
+                if(id == this->nodeId) continue; // don't send to ourselfs
+                if(i+1 == nodes.size()) message->setReleasePayload(true); // release payload on last send
+                sendMessage( message, id, service );
         }
 }