Changeset 5464 for source

Timestamp:

Jul 30, 2009, 8:40:28 AM (15 years ago)

Author:

Christoph Mayer

Message:

-periodic broadcast fix

Location:

source/ariba

Files:

• communication/modules/transport/tcp/TCPTransport.cpp (modified) (1 diff)
• overlay/BaseOverlay.cpp (modified) (1 diff)
• utility/bootstrap/modules/periodicbroadcast/PeriodicBroadcast.h (modified) (2 diffs)

source/ariba/communication/modules/transport/tcp/TCPTransport.cpp

@@ -203 +203 @@
                                         // converting message
                                         logging_debug( "converting message" );
-                                        //std::cout << "XXXXXXXXXXXXreceived data on tcp transport: " << data << std::endl;
                                         Message* msg = new Message(data);
 

source/ariba/overlay/BaseOverlay.cpp

@@ -241 +241 @@
         bc(NULL), overlayInterface(NULL), nodeId(NodeID::UNSPECIFIED),
         spovnetId(SpoVNetID::UNSPECIFIED), state(BaseOverlayStateInvalid),
-        sideport(&SideportListener::DEFAULT), started(false) {
+        sideport(&SideportListener::DEFAULT), started(false), counter(0) {
 }
 

source/ariba/utility/bootstrap/modules/periodicbroadcast/PeriodicBroadcast.h

@@ -131 +131 @@
                 udp::socket socket_v6;
                 udp::endpoint remote_endpoint_;
-                boost::array<char, 1500> recv_buffer_;
+                boost::array<char, 1500> recv_buffer_4;
+                boost::array<char, 1500> recv_buffer_6;
                 ServiceList* services;
                 boost::mutex* servicesmutex;
@@ -203 +204 @@
                 void start_receive(){
                         socket_v4.async_receive_from(
-                                        boost::asio::buffer(recv_buffer_), remote_endpoint_,
-                                        boost::bind(&udp_server::handle_receive, this,
+                                        boost::asio::buffer(recv_buffer_4), remote_endpoint_,
+                                        boost::bind(&udp_server::handle_receive_4, this,
                                                         boost::asio::placeholders::error,
                                                         boost::asio::placeholders::bytes_transferred));
 
                         socket_v6.async_receive_from(
-                                        boost::asio::buffer(recv_buffer_), remote_endpoint_,
-                                        boost::bind(&udp_server::handle_receive, this,
+                                        boost::asio::buffer(recv_buffer_6), remote_endpoint_,
+                                        boost::bind(&udp_server::handle_receive_6, this,
                                                         boost::asio::placeholders::error,
                                                         boost::asio::placeholders::bytes_transferred));
                 }
 
-                void handle_receive(const boost::system::error_code& error,
+                void handle_receive_4(const boost::system::error_code& error,
                                 std::size_t bytes_transferred){
 
-                        if (!error || error == boost::asio::error::message_size){
-
-                                PeriodicBroadcastMessage msg;
-                                Data data( (uint8_t*)recv_buffer_.data(), bytes_transferred*8 );
-                                data_deserialize( msg, data );
-
-                                { // insert new found service
-                                        boost::mutex::scoped_lock( *servicesmutex );
-
-                                        ServiceList::iterator it = services->find( msg.getName() );
-                                        if( it != services->end() ){
-
-                                                it->second.info1 = msg.getInfo1();
-                                                it->second.info2 = msg.getInfo2();
-                                                it->second.info3 = msg.getInfo3();
-                                                it->second.lastseen = time(NULL);
-
-                                        } else {
-                                                Service s( msg.getName(), msg.getInfo1(), msg.getInfo2(), msg.getInfo3(), time(NULL));
-                                                services->insert( std::make_pair(msg.getName(), s) );
-                                        }
+                        if (!error || error == boost::asio::error::message_size)
+                                handle_info(recv_buffer_4, bytes_transferred);
+                        else
+                                logging_warn("failed receiving broadcast data: " << error.message());
+
+                        start_receive();
+                }
+
+                void handle_receive_6(const boost::system::error_code& error,
+                                std::size_t bytes_transferred){
+
+                        if (!error || error == boost::asio::error::message_size)
+                                handle_info(recv_buffer_6, bytes_transferred);
+                        else
+                                logging_warn("failed receiving broadcast data: " << error.message());
+
+                        start_receive();
+                }
+
+                void handle_info(boost::array<char, 1500>& buffer, std::size_t length){
+                        PeriodicBroadcastMessage msg;
+
+                        Data data( (uint8_t*)buffer.data(), length*8 );
+                        data_deserialize( msg, data );
+
+                        { // insert new found service
+                                boost::mutex::scoped_lock( *servicesmutex );
+
+                                ServiceList::iterator it = services->find( msg.getName() );
+                                if( it != services->end() ){
+
+                                        it->second.info1 = msg.getInfo1();
+                                        it->second.info2 = msg.getInfo2();
+                                        it->second.info3 = msg.getInfo3();
+                                        it->second.lastseen = time(NULL);
+
+                                } else {
+                                        Service s( msg.getName(), msg.getInfo1(), msg.getInfo2(), msg.getInfo3(), time(NULL));
+                                        services->insert( std::make_pair(msg.getName(), s) );
                                 }
-
-                                start_receive();
-                        } else {
-
-                                logging_warn("failed receiving message on ipv4 socket" << error);
-
                         }
                 }