Changeset 4920 for source


Ignore:
Timestamp:
Jul 15, 2009, 7:42:25 AM (15 years ago)
Author:
Christoph Mayer
Message:

-bootstrap fixing und ablauf

Location:
source/ariba
Files:
3 edited

Legend:

Unmodified
Added
Removed
  • source/ariba/overlay/OverlayBootstrap.cpp

    r4919 r4920  
    6262
    6363        manager.registerCallback( this );
    64         //manager.registerModule( BootstrapManager::BootstrapTypePeriodicBroadcast );
     64        manager.registerModule( BootstrapManager::BootstrapTypePeriodicBroadcast );
    6565}
    6666void OverlayBootstrap::stop(){
     
    7070
    7171        manager.unregisterCallback( this );
    72         //manager.unregisterModule( BootstrapManager::BootstrapTypePeriodicBroadcast );
     72        manager.unregisterModule( BootstrapManager::BootstrapTypePeriodicBroadcast );
    7373}
    7474
  • source/ariba/utility/bootstrap/modules/periodicbroadcast/PeriodicBroadcast.cpp

    r4866 r4920  
    6666        : BootstrapModule(_callback),
    6767        server(io_service, &newRemoteServices, &newRemoteServicesMutex) {
     68
     69        io_service.run();
    6870}
    6971
    7072PeriodicBroadcast::~PeriodicBroadcast(){
     73        io_service.stop();
    7174}
    7275
  • source/ariba/utility/bootstrap/modules/periodicbroadcast/PeriodicBroadcast.h

    r4910 r4920  
    116116        class udp_server {
    117117        private:
    118                 udp::socket socket_v4_listen;
    119                 udp::socket socket_v4_send;
    120                 //udp::socket socket_v6;
     118                udp::socket socket_v4;
     119                udp::socket socket_v6;
    121120                udp::endpoint remote_endpoint_;
    122121                boost::array<char, 1500> recv_buffer_;
     
    127126                udp_server(boost::asio::io_service& io_service, ServiceList* _services, boost::mutex* _servicesmutex)
    128127                        : services(_services), servicesmutex(_servicesmutex),
    129                                 socket_v4_listen(io_service), socket_v4_send(io_service) /*, socket_v6(io_service)*/ {
     128                                socket_v4(io_service), socket_v6(io_service) {
    130129
    131130                        boost::asio::ip::udp::endpoint listen_endpoint_v4(
    132                                         boost::asio::ip::udp::v4() /*boost::asio::ip::address_v4::any()*/,
     131                                        boost::asio::ip::address_v4::any(),
    133132                                        PeriodicBroadcast::serverport_v4);
    134133
    135 /*
    136134                        boost::asio::ip::udp::endpoint listen_endpoint_v6(
    137                                         boost::asio::ip::address_v6::from_string("ff02::1"),
     135                                        boost::asio::ip::address_v6::any(),
    138136                                        PeriodicBroadcast::serverport_v6);
    139 */
    140137
    141138                        boost::system::error_code err;
    142139
    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");
    164                        
    165                         //socket_v6.bind( listen_endpoint_v6 );
     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");
     160
     161                        err = socket_v6.bind( listen_endpoint_v6 );
     162                        if(err) logging_warn("failed binding ipv6 socket");
    166163
    167164                        start_receive();
     
    182179                                udp::endpoint endp(udp::v4(), PeriodicBroadcast::serverport_v4);
    183180                                endp.address( boost::asio::ip::address_v4::broadcast() );
    184                                 socket_v4_send.send_to( boost::asio::buffer(pnt, len), endp, 0, err );
     181                                socket_v4.send_to( boost::asio::buffer(pnt, len), endp, 0, err );
    185182                                if(err) logging_warn("failed sending message through ipv4 socket");
    186183                        }
    187                         {/*
     184                        {
    188185                                udp::endpoint endp(udp::v6(), PeriodicBroadcast::serverport_v6);
    189186                                endp.address( boost::asio::ip::address_v6::from_string("ff02::1") );
    190187                                socket_v6.send_to( boost::asio::buffer(pnt, len), endp, 0, ignored_error );
    191                         */}
     188                        }
    192189                }
    193190
    194191        private:
    195192                void start_receive(){
    196                         socket_v4_listen.async_receive_from(
     193                        socket_v4.async_receive_from(
    197194                                        boost::asio::buffer(recv_buffer_), remote_endpoint_,
    198195                                        boost::bind(&udp_server::handle_receive, this,
    199196                                                        boost::asio::placeholders::error,
    200197                                                        boost::asio::placeholders::bytes_transferred));
    201 /*
     198
    202199                        socket_v6.async_receive_from(
    203200                                        boost::asio::buffer(recv_buffer_), remote_endpoint_,
     
    205202                                                        boost::asio::placeholders::error,
    206203                                                        boost::asio::placeholders::bytes_transferred));
    207 */
    208204                }
    209205
     
    244240                                const boost::system::error_code& error,
    245241                                std::size_t /*bytes_transferred*/){
    246        
     242
    247243                        if(error)
    248244                                logging_warn("failed sending out message");
    249                
     245
    250246                }
    251247
     
    253249
    254250        udp_server server;
     251
    255252};
    256253
Note: See TracChangeset for help on using the changeset viewer.