Ignore:
Timestamp:
Jul 14, 2009, 4:34:14 PM (15 years ago)
Author:
huebsch
Message:

bootstrap testing

File:
1 edited

Legend:

Unmodified
Added
Removed
  • source/ariba/utility/bootstrap/modules/periodicbroadcast/PeriodicBroadcast.h

    r4896 r4910  
    116116        class udp_server {
    117117        private:
    118                 udp::socket socket_v4;
    119                 udp::socket socket_v6;
     118                udp::socket socket_v4_listen;
     119                udp::socket socket_v4_send;
     120                //udp::socket socket_v6;
    120121                udp::endpoint remote_endpoint_;
    121122                boost::array<char, 1500> recv_buffer_;
     
    126127                udp_server(boost::asio::io_service& io_service, ServiceList* _services, boost::mutex* _servicesmutex)
    127128                        : services(_services), servicesmutex(_servicesmutex),
    128                                 socket_v4(io_service), socket_v6(io_service) {
     129                                socket_v4_listen(io_service), socket_v4_send(io_service) /*, socket_v6(io_service)*/ {
    129130
    130131                        boost::asio::ip::udp::endpoint listen_endpoint_v4(
    131                                         boost::asio::ip::address_v4::broadcast(),
     132                                        boost::asio::ip::udp::v4() /*boost::asio::ip::address_v4::any()*/,
    132133                                        PeriodicBroadcast::serverport_v4);
    133134
     135/*
    134136                        boost::asio::ip::udp::endpoint listen_endpoint_v6(
    135137                                        boost::asio::ip::address_v6::from_string("ff02::1"),
    136138                                        PeriodicBroadcast::serverport_v6);
     139*/
    137140
    138141                        boost::system::error_code err;
    139142
    140                         err = socket_v4.open( listen_endpoint_v4.protocol(), err );
    141                         if(err) logging_warn("failed opening ipv4 socket");
    142 
    143                         err = socket_v6.open( listen_endpoint_v6.protocol(), err );
    144                         if(err) logging_warn("failed opening ipv6 socket");
    145 
    146                         err = socket_v4.set_option( boost::asio::ip::udp::socket::reuse_address(true), err );
    147                         if(err) logging_warn("failed setting reuse address option on ipv4 socket");
    148 
    149                         err = socket_v6.set_option( boost::asio::ip::udp::socket::reuse_address(true), err );
    150                         if(err) logging_warn("failed setting reuse address option on ipv6 socket");
    151 
    152                         err = socket_v4.set_option( boost::asio::socket_base::broadcast(true), err );
    153                         if(err) logging_warn("failed setting broadcast option on ipv4 socket");
    154 
    155                         err = socket_v6.set_option( boost::asio::socket_base::broadcast(true), err );
    156                         if(err) logging_warn("failed setting broadcast option on ipv6 socket");
    157 
    158                         err = socket_v4.bind( listen_endpoint_v4, err );
    159                         if(err) logging_warn("failed binding ipv4 socket");
     143                        //err = socket_v4.open( listen_endpoint_v4.protocol(), err );
     144                        //if(err) logging_warn("failed opening ipv4 socket");
     145
     146                        //err = socket_v6.open( listen_endpoint_v6.protocol(), err );
     147                        //if(err) logging_warn("failed opening ipv6 socket");
     148
     149                        //err = socket_v4.set_option( boost::asio::ip::udp::socket::reuse_address(true), err );
     150                        //if(err) logging_warn("failed setting reuse address option on ipv4 socket");
     151
     152                        //err = socket_v6.set_option( boost::asio::ip::udp::socket::reuse_address(true), err );
     153                        //if(err) logging_warn("failed setting reuse address option on ipv6 socket");
     154
     155                        err = socket_v4_listen.set_option( boost::asio::socket_base::broadcast(true), err );
     156                        err = socket_v4_send.set_option( boost::asio::socket_base::broadcast(true), err );
     157                        //if(err) logging_warn("failed setting broadcast option on ipv4 socket");
     158
     159                        //err = socket_v6.set_option( boost::asio::socket_base::broadcast(true), err );
     160                        //if(err) logging_warn("failed setting broadcast option on ipv6 socket");
     161
     162                        //err = socket_v4.bind( listen_endpoint_v4, err );
     163                        //if(err) logging_warn("failed binding ipv4 socket");
    160164                       
    161165                        //socket_v6.bind( listen_endpoint_v6 );
     
    178182                                udp::endpoint endp(udp::v4(), PeriodicBroadcast::serverport_v4);
    179183                                endp.address( boost::asio::ip::address_v4::broadcast() );
    180                                 socket_v4.send_to( boost::asio::buffer(pnt, len), endp, 0, err );
     184                                socket_v4_send.send_to( boost::asio::buffer(pnt, len), endp, 0, err );
    181185                                if(err) logging_warn("failed sending message through ipv4 socket");
    182186                        }
     
    190194        private:
    191195                void start_receive(){
    192                         socket_v4.async_receive_from(
     196                        socket_v4_listen.async_receive_from(
    193197                                        boost::asio::buffer(recv_buffer_), remote_endpoint_,
    194198                                        boost::bind(&udp_server::handle_receive, this,
    195199                                                        boost::asio::placeholders::error,
    196200                                                        boost::asio::placeholders::bytes_transferred));
    197 
     201/*
    198202                        socket_v6.async_receive_from(
    199203                                        boost::asio::buffer(recv_buffer_), remote_endpoint_,
     
    201205                                                        boost::asio::placeholders::error,
    202206                                                        boost::asio::placeholders::bytes_transferred));
     207*/
    203208                }
    204209
     
    248253
    249254        udp_server server;
    250 
    251255};
    252256
Note: See TracChangeset for help on using the changeset viewer.