boost :: asio и boost :: bind error - PullRequest
Новая
       37

boost :: asio и boost :: bind error

0 голосов
/ 11 июля 2011

Этот вопрос немного раздражает, я не могу получить следующий код для компиляции.Вам нужно будет скомпилировать приведенный ниже код.

У меня возникли некоторые проблемы с boost asio, я пытаюсь абстрагировать логику приема соединений в единую абстракцию, чтобы я мог инициировать соединение для окон named-pipe иДоменные сокеты Unix единообразно с обычным TCP / IP.

В приведенном ниже коде показано 3 класса, первые 2 являются реализациями принятия TCP-соединений, а третий класс ниже представляет собой обобщенный класс, который реализован вусловия первого 2. У меня проблемы с boost::bind звонками.Проблема, вероятно, заключается в моем понимании семантики.

Если я сделаю TcpDestinationAcceptor::handle_accept обычной функцией-членом (--ie, а не функцией-членом шаблона), в результате я не передам параметр AcceptHandler.Код компилируется нормально.Примечание. Я не удаляю статус функции шаблона из TcpDestinationAcceptor::StartAccepting.

Примечание. Я уже начал использовать другой дизайн, но все же я хотел бы продолжить этот проект, если это возможно.

Автономный код: 

#include <boost/asio/ip/tcp.hpp>
#include <boost/asio/io_service.hpp>
#include <boost/shared_ptr.hpp>
#include <boost/bind.hpp>
#include <boost/asio/placeholders.hpp>

class TcpDestinationConnection
{
public:
  typedef boost::asio::ip::tcp::socket t_io_object;
  TcpDestinationConnection(boost::asio::io_service & io_s)
    : m_io_object(io_s) {} ;
  t_io_object & io_object() { return m_io_object; }
private:
  t_io_object m_io_object;
};

class TcpDestinationAcceptor
{
public:
  typedef boost::asio::ip::tcp::acceptor t_acceptor;
  typedef boost::shared_ptr<TcpDestinationConnection> t_connection_ptr;


  TcpDestinationAcceptor( boost::asio::io_service & io_s)
    : m_io_service(io_s),
      m_acceptor(io_s) 
  {
    m_acceptor.open(boost::asio::ip::tcp::v4());
  }

  TcpDestinationAcceptor( boost::asio::io_service & io_s , 
                          const boost::asio::ip::tcp::endpoint & endpoint)
    : m_io_service(io_s),
      m_acceptor(io_s, endpoint) 
    {
      m_acceptor.open(boost::asio::ip::tcp::v4());
    }

  t_acceptor & acceptor() { return m_acceptor; } 

  template<typename AcceptHandler>
  void StartAccepting(AcceptHandler h)
  {   
    t_connection_ptr new_session(new TcpDestinationConnection(m_io_service));

    m_acceptor.async_accept(  new_session->io_object(),
                              boost::bind(  &TcpDestinationAcceptor::handle_accept<AcceptHandler>, this,
                                              boost::asio::placeholders::error, new_session, h));
  }

  template<typename AcceptHandler>
  void handle_accept(const boost::system::error_code & err, t_connection_ptr cur, AcceptHandler h)  {
  }
private:
  boost::asio::io_service & m_io_service;
  boost::asio::ip::tcp::acceptor m_acceptor;
};

template<typename t_acceptor>
class ConnectionOracle
{
public:
  ConnectionOracle()
    : m_io_service(),
      m_acceptor(m_io_service) {}

  typename t_acceptor::t_acceptor & native_acceptor() { return m_acceptor.acceptor(); }
  boost::asio::io_service & io_service() { return m_io_service; }

  void StartConnection( typename t_acceptor::t_connection_ptr connection,
                        boost::system::error_code & error)
  {

  }
  void Begin()
  {
    m_acceptor.StartAccepting(  boost::bind(  &ConnectionOracle::StartConnection,this,
                                              _1,
                                              boost::asio::placeholders::error));
    m_io_service.run();
  } 
private:
  boost::asio::io_service m_io_service;
  t_acceptor m_acceptor;
};

int main()
{
  ConnectionOracle<TcpDestinationAcceptor> ConOracle;
  ConOracle.native_acceptor().
    bind(boost::asio::ip::tcp::endpoint(boost::asio::ip::tcp::v4(),50000));
  ConOracle.Begin();

  return 0;
}
...