Changeset 3712 for source/ariba/overlay/BaseOverlay.h

Timestamp:

May 26, 2009, 8:03:39 PM (15 years ago)

Author:

Christoph Mayer

Message:

-autolink message buffer von basecomm nach baseoverlay und komplette logik hochgezogen damit mit neuem overlay routing zurecht kommt, damit ist letzer fehler raus

File:

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

source/ariba/overlay/BaseOverlay.h

@@ -46 +46 @@
 #include <list>
 #include <vector>
+#include <deque>
 #include <boost/foreach.hpp>
 
@@ -80 +81 @@
 using std::pair;
 using std::find;
+using std::deque;
 
 using ariba::NodeListener;
@@ -420 +422 @@
 
                 LinkItem() :
-                        link(LinkID::UNSPECIFIED), node(NodeID::UNSPECIFIED), service(
-                                        ServiceID::UNSPECIFIED), interface(
-                                        &CommunicationListener::DEFAULT), autolink(false), lastuse(
-                                        0) {
+                        link(LinkID::UNSPECIFIED),
+                        node(NodeID::UNSPECIFIED),
+                        service(ServiceID::UNSPECIFIED),
+                        interface(&CommunicationListener::DEFAULT),
+                        autolink(false),
+                        lastuse(0),
+                        linkup(false){
                 }
 
                 LinkItem(const LinkID& _link, const NodeID& _node,
                                 const ServiceID& _service, CommunicationListener* _interface) :
-                        link(_link), node(_node), service(_service), interface(_interface),
-                                        autolink(false), lastuse(time(NULL)) {
+                        link(_link),
+                        node(_node),
+                        service(_service),
+                        interface(_interface),
+                        autolink(false),
+                        lastuse(time(NULL)),
+                        linkup(false){
 
                         assert( _interface != NULL );
                 }
 
+                LinkItem(const LinkItem& rh) :
+                        link(rh.link),
+                        node(rh.node),
+                        service(rh.service),
+                        interface(rh.interface),
+                        autolink(rh.autolink),
+                        lastuse(rh.lastuse),
+                        linkup(rh.linkup){
+
+                        BOOST_FOREACH( Message* msg, rh.waitingmsg ){
+                                waitingmsg.push_back( msg );
+                        }
+                }
+
+                void deleteWaiting(){
+                        BOOST_FOREACH( Message* msg, waitingmsg ){
+                                delete msg;
+                        }
+                        waitingmsg.clear();
+                }
+
                 // general information about the link
-
                 const LinkID link;
                 NodeID node;
                 ServiceID service;
                 CommunicationListener* interface;
+                bool linkup;
 
                 // information needed for auto links
@@ -448 +479 @@
                 bool autolink;
                 time_t lastuse;
+                deque<Message*> waitingmsg;
         };
 
@@ -467 +499 @@
 };
 
-}
-} // namespace ariba, overlay
+}} // namespace ariba, overlay
 
 #endif /*BASEOVERLAY_H_*/