Changeset 5444

Timestamp:

Jul 29, 2009, 5:33:41 PM (15 years ago)

Author:

mies

Message:

 

Location:

source/ariba

Files:

• overlay/BaseOverlay.cpp (modified) (1 diff)
• utility/transport/rfcomm/rfcomm.cpp (modified) (4 diffs)
• utility/transport/tcpip/tcpip.cpp (modified) (1 diff)

source/ariba/overlay/BaseOverlay.cpp

@@ -1375 +1375 @@
                 // ---------------------------------------------------------------------
                 case OverlayMsg::typeKeepAlive: {
-
                         logging_debug( "received keep-alive on link" );
-
                         if ( ld != NULL ) {
-                                //logging_force("Keep-Alive for "<< ld->overlayId);
+                                logging_force("Keep-Alive for "<< ld->overlayId);
                                 ld->markAlive();
                         }

source/ariba/utility/transport/rfcomm/rfcomm.cpp

@@ -150 +150 @@
                         boost::asio::placeholders::error, info
                 ));
-                asio_io_service::start();
         }
 
@@ -169 +168 @@
 
         // start writing
-        start_write(info);
+        io.post( boost::bind( &rfcomm::start_write, this, info) );
 }
 
@@ -293 +292 @@
 
 void rfcomm::start_read(link_info* info) {
+        logging_debug("Start reading ...");
+
         // start read
         boost::asio::async_read(*info->socket,
@@ -367 +368 @@
         // deliver data
         listener->receive_message(this, info->local, info->remote, info->buffer, info->size );
+
+        logging_debug( "Message delivered to service!");
 
         // free buffers and reset size buffer

source/ariba/utility/transport/tcpip/tcpip.cpp

@@ -195 +195 @@
                         tp.listener->receive_message(
                                         &tp, local, remote, datamsg->get_buffer()+6, message_size );
+
+                        delete datamsg;
                 }
         }