0

Boost ASIOの使い方を学んでいます。これは、Boost doc のチャットの例から適用された私のコードです。

class AsioCommunicationService {
AsioCommunicationService::AsioCommunicationService(
        boost::asio::io_service& io_service,
        tcp::resolver::iterator endpoint_iterator)
    : io_service_(io_service),
      socket_(io_service)
{
    boost::asio::async_connect(socket_, endpoint_iterator,
        boost::bind(&AsioCommunicationService::handle_connect, this,
        boost::asio::placeholders::error));
}



void AsioCommunicationService::handle_connect(const boost::system::error_code& error)
{
    if (!error)
    {
      boost::asio::async_read(socket_,
          boost::asio::buffer(read_msg_.data(), LampMessage::header_length),
          boost::bind(&AsioCommunicationService::handle_read_header, this,
          boost::asio::placeholders::error));
    }
}
}


class Connection
{
    m_session = std::shared_ptr<AsioCommunicationService>(
            new AsioCommunicationService(io_service, iterator));
    boost::thread t(boost::bind(&boost::asio::io_service::run, &io_service));
}

コンパイル時に、「async_connect」は「boost::asio」のメンバーではないというエラーが表示されました。明らかに、async_connect はブースト asio のメンバーではなく、ソケットのメンバーです。IDE が教えてくれる限りです。libasiodev 1.41.3 を使用しています。

これへの呼び出しを変更しようとしました

tcp::endpoint endpoint = *endpoint_iterator;
socket_.async_connect(endpoint,
    boost::bind(&AsioCommunicationService::handle_connect, this,
    boost::asio::placeholders::error, ++endpoint_iterator));
//Got this error: instantiated from ‘boost::_bi::bind_t<boost::_bi::unspecified, void (networkService::AsioCommunicationService::*)(const boost::system::error_code&), boost::_bi::list3<boost::_bi::value<networkService::AsioCommunicationService*>, boost::arg<1> (*)(), boost::_bi::value<boost::asio::ip::basic_resolver_iterator<boost::asio::ip::tcp> > > >’

更新: handle_connect 署名を変更して反復子パラメーターを含めた後、その行を正常にコンパイルしました。ただし、コンパイラは現在、thread.hpp へのインクルードでスタックしています。

#include <boost/thread.hpp>
//ERROR: In function ‘boost::thread&& boost::move(boost::thread&&)’:
///usr/include/boost/thread/detail/thread.hpp:349:16: error: invalid initialization of reference of type ‘boost::thread&&’ from expression of type ‘boost::thread’
//In file included from /usr/include/boost/thread/detail/thread_heap_alloc.hpp:17:0,
//             from /usr/include/boost/thread/detail/thread.hpp:13,
//             from /usr/include/boost/thread/thread.hpp:22,
//             from /usr/include/boost/thread.hpp:13,
//             from /home/son/dev/logistics/src/frameworks/networkService/NetworkConnection.cpp:13:
///usr/include/boost/thread/pthread/thread_heap_alloc.hpp: In function ‘T* boost::detail::heap_new(A1&&) [with T = boost::detail::thread_data<void (*)()>, A1 = void (*&)()]’:
///usr/include/boost/thread/detail/thread.hpp:130:95:   instantiated from here
///usr/include/boost/thread/pthread/thread_heap_alloc.hpp:24:47: error: cannot bind ‘void (*)()’ lvalue to ‘void (*&&)()’
///usr/include/boost/thread/detail/thread.hpp:43:13: error:   initializing argument 1 of ‘boost::detail::thread_data<F>::thread_data(F&&) [with F = void (*)()]’

何らかの理由で、boost::thread t(boost::bind(&boost::asio::io_service::run, &io_service)); の呼び出しで新しいスレッドを開始できません。io_service.run(); への単純な呼び出しで置き換えると機能しますが、

4

1 に答える 1

2

あなたのCBには署名があるので

void AsioCommunicationService::handle_connect(const boost::system::error_code& error)

この呼び出しは正しくありません。

tcp::endpoint endpoint = *endpoint_iterator;
socket_.async_connect(endpoint,
    boost::bind(&AsioCommunicationService::handle_connect, this,
    boost::asio::placeholders::error, ++endpoint_iterator));

あなたの最後のパーは間違っているので、右のバインドは

boost::bind(&AsioCommunicationService::handle_connect, this,
        boost::asio::placeholders::error));
于 2012-07-30T10:13:40.463 に答える