Changeset 4896 for source/ariba/utility

Timestamp:

Jul 14, 2009, 11:03:23 AM (15 years ago)

Author:

huebsch

Message:

-error handling

File:

• source/ariba/utility/bootstrap/modules/periodicbroadcast/PeriodicBroadcast.h (modified) (3 diffs)

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

@@ -136 +136 @@
                                         PeriodicBroadcast::serverport_v6);
 
-                        socket_v4.open( listen_endpoint_v4.protocol() );
-                        socket_v6.open( listen_endpoint_v6.protocol() );
-
-                        socket_v4.set_option( boost::asio::ip::udp::socket::reuse_address(true) );
-                        socket_v6.set_option( boost::asio::ip::udp::socket::reuse_address(true) );
-
-                        socket_v4.set_option( boost::asio::socket_base::broadcast(true) );
-                        socket_v6.set_option( boost::asio::socket_base::broadcast(true) );
-
-                        socket_v4.bind( listen_endpoint_v4 );
+                        boost::system::error_code err;
+
+                        err = socket_v4.open( listen_endpoint_v4.protocol(), err );
+                        if(err) logging_warn("failed opening ipv4 socket");
+
+                        err = socket_v6.open( listen_endpoint_v6.protocol(), err );
+                        if(err) logging_warn("failed opening ipv6 socket");
+
+                        err = socket_v4.set_option( boost::asio::ip::udp::socket::reuse_address(true), err );
+                        if(err) logging_warn("failed setting reuse address option on ipv4 socket");
+
+                        err = socket_v6.set_option( boost::asio::ip::udp::socket::reuse_address(true), err );
+                        if(err) logging_warn("failed setting reuse address option on ipv6 socket");
+
+                        err = socket_v4.set_option( boost::asio::socket_base::broadcast(true), err );
+                        if(err) logging_warn("failed setting broadcast option on ipv4 socket");
+
+                        err = socket_v6.set_option( boost::asio::socket_base::broadcast(true), err );
+                        if(err) logging_warn("failed setting broadcast option on ipv6 socket");
+
+                        err = socket_v4.bind( listen_endpoint_v4, err );
+                        if(err) logging_warn("failed binding ipv4 socket");
+                        
                         //socket_v6.bind( listen_endpoint_v6 );
 
@@ -160 +173 @@
 
                         cout << "-----------> sending out " << data << std::endl;
+                        boost::system::error_code err;
 
                         {
                                 udp::endpoint endp(udp::v4(), PeriodicBroadcast::serverport_v4);
                                 endp.address( boost::asio::ip::address_v4::broadcast() );
-                                socket_v4.send_to( boost::asio::buffer(pnt, len), endp, 0, ignored_error );
+                                socket_v4.send_to( boost::asio::buffer(pnt, len), endp, 0, err );
+                                if(err) logging_warn("failed sending message through ipv4 socket");
                         }
-                        {
+                        {/*
                                 udp::endpoint endp(udp::v6(), PeriodicBroadcast::serverport_v6);
                                 endp.address( boost::asio::ip::address_v6::from_string("ff02::1") );
                                 socket_v6.send_to( boost::asio::buffer(pnt, len), endp, 0, ignored_error );
-                        }
+                        */}
                 }
 
@@ -214 +229 @@
 
                                 start_receive();
+                        } else {
+
+                                logging_warn("failed receiving message on ipv4 socket" << error);
+
                         }
                 }
 
                 void handle_send(boost::shared_ptr<std::string> /*message*/,
-                                const boost::system::error_code& /*error*/,
+                                const boost::system::error_code& error,
                                 std::size_t /*bytes_transferred*/){
+        
+                        if(error)
+                                logging_warn("failed sending out message");
+                
                 }