Changeset 3037 for source/ariba/communication/BaseCommunication.cpp

Timestamp:

Apr 22, 2009, 9:07:53 PM (15 years ago)

Author:

Christoph Mayer

Message:

-jede Menge fixes und Umstellungen
-angefangen ariba/interface los zu werden, erste dateien sind weg

File:

• source/ariba/communication/BaseCommunication.cpp (modified) (8 diffs)

source/ariba/communication/BaseCommunication.cpp

@@ -55 +55 @@
 const BaseCommunication::LinkDescriptor BaseCommunication::LinkDescriptor::UNSPECIFIED;
 
-BaseCommunication::BaseCommunication(const NetworkLocator* _locallocator, const uint16_t _listenport)
-        : messageReceiver( NULL ), currentSeqnum( 0 ), listenport( _listenport ) {
+BaseCommunication::BaseCommunication()
+        : messageReceiver(NULL), network(NULL), transport(NULL){
+}
+
+BaseCommunication::~BaseCommunication(){
+}
+
+void BaseCommunication::start(const NetworkLocator* _locallocator, const uint16_t _listenport){
+
+        currentSeqnum = 0;
+        listenport = _listenport;
 
         logging_info( "starting up base communication and creating transports ..." );
@@ -139 +148 @@
 }
 
-BaseCommunication::~BaseCommunication() {
+void BaseCommunication::stop() {
 
         logging_info( "stopping base communication and transport ..." );
@@ -210 +219 @@
         // warn if this link has some queued messages attached
         if( descriptor.waitingmsg.size() > 0 ){
-                logging_warn( "dropping link " << link.toString() << 
+                logging_warn( "dropping link " << link.toString() <<
                         " that has " << descriptor.waitingmsg.size() << " waiting messages" );
         }
@@ -368 +377 @@
                 const NetworkLocator* remoteLocator = dynamic_cast<const NetworkLocator*>(message->getSourceAddress());
 
-                logging_debug( "localLocator=" << localLocator->toString() 
+                logging_debug( "localLocator=" << localLocator->toString()
                                 << " remoteLocator=" << remoteLocator->toString());
 
@@ -419 +428 @@
                 // the link is now open
                 //
-                
+
                 BOOST_FOREACH( CommunicationEvents* i, eventListener ){
                         i->onLinkUp( localLink, localLocator, remoteLocator );
@@ -444 +453 @@
 
                 linkDesc.remoteLink = spovmsg->getLocalLink();
-                linkDesc.linkup = true; 
-        
+                linkDesc.linkup = true;
+
                 logging_debug( "the link is now up with local link id " << spovmsg->getRemoteLink().toString() );
 
@@ -452 +461 @@
                 }
 
-                if( linkDesc.waitingmsg.size() > 0 ){ 
+                if( linkDesc.waitingmsg.size() > 0 ){
                         logging_info( "sending out queued messages on link " << linkDesc.localLink.toString() );
 
@@ -564 +573 @@
         for( ; i != iend; i++){
                 if( (*i).localLink != localLink) continue;
-                
+
                 BOOST_FOREACH( Message* msg, i->waitingmsg ){
                         delete msg;