AsyncAcceptor Class Reference

#include <AsyncAcceptor.h>

Public Types
typedef void(*	AcceptCallback )(tcp::socket &&newSocket, uint32 threadIndex)

Public Member Functions
	AsyncAcceptor (boost::asio::io_service &ioService, std::string const &bindIp, uint16 port)
template<class T >
void	AsyncAccept ()
template<AcceptCallback acceptCallback>
void	AsyncAcceptWithCallback ()
void	Close ()
void	SetSocketFactory (std::function< std::pair< tcp::socket *, uint32 >()> func)

Private Member Functions
std::pair< tcp::socket *, uint32 >	DefeaultSocketFactory ()

Private Attributes
tcp::acceptor	_acceptor
tcp::socket	_socket
std::atomic< bool >	_closed
std::function< std::pair < tcp::socket *, uint32 >)>	_socketFactory

Member Typedef Documentation

typedef void(* AsyncAcceptor::AcceptCallback)(tcp::socket &&newSocket, uint32 threadIndex)

Constructor & Destructor Documentation

AsyncAcceptor::AsyncAcceptor ( boost::asio::io_service &  ioService, std::string const &  bindIp, uint16  port  )

inline

 :
 _acceptor(ioService, tcp::endpoint(boost::asio::ip::address::from_string(bindIp), port)),
 _socket(ioService), _closed(false), _socketFactory(std::bind(&AsyncAcceptor::DefeaultSocketFactory, this))
 {
 }

Member Function Documentation

template<class T >

void AsyncAcceptor::AsyncAccept

(

)

{
 _acceptor.async_accept(_socket, [this](boost::system::error_code error)
 {
 if (!error)
 {
 try
 {
 // this-> is required here to fix an segmentation fault in gcc 4.7.2 - reason is lambdas in a templated class
 std::make_shared<T>(std::move(this->_socket))->Start();
 }
 catch (boost::system::system_error const& err)
 {
 TC_LOG_INFO("network", "Failed to retrieve client's remote address %s", err.what());
 }
 }

 // lets slap some more this-> on this so we can fix this bug with gcc 4.7.2 throwing internals in yo face
 if (!_closed)
 this->AsyncAccept<T>();
 });
}

Here is the caller graph for this function:

template<AcceptCallback acceptCallback>

void AsyncAcceptor::AsyncAcceptWithCallback ( )

inline

 {
 tcp::socket* socket;
 uint32 threadIndex;
 std::tie(socket, threadIndex) = _socketFactory();
 _acceptor.async_accept(*socket, [this, socket, threadIndex](boost::system::error_code error)
 {
 if (!error)
 {
 try
 {
 socket->non_blocking(true);

 acceptCallback(std::move(*socket), threadIndex);
 }
 catch (boost::system::system_error const& err)
 {
 TC_LOG_INFO("network", "Failed to initialize client's socket %s", err.what());
 }
 }

 if (!_closed)
 this->AsyncAcceptWithCallback<acceptCallback>();
 });
 }

Here is the caller graph for this function:

void AsyncAcceptor::Close ( )

inline

 {
 if (_closed.exchange(true))
 return;

 boost::system::error_code err;
 _acceptor.close(err);
 }

Here is the caller graph for this function:

std::pair<tcp::socket*, uint32> AsyncAcceptor::DefeaultSocketFactory ( )

inlineprivate

{ return std::make_pair(&_socket, 0); }

void AsyncAcceptor::SetSocketFactory ( std::function< std::pair< tcp::socket *, uint32 >()>  func )

inline

{ _socketFactory = func; }

Here is the caller graph for this function:

Member Data Documentation

tcp::acceptor AsyncAcceptor::_acceptor

private

std::atomic<bool> AsyncAcceptor::_closed

private

tcp::socket AsyncAcceptor::_socket

private

std::function<std::pair<tcp::socket*, uint32>)> AsyncAcceptor::_socketFactory

private

---

The documentation for this class was generated from the following file:

• src/server/shared/Networking/AsyncAcceptor.h