diff options
Diffstat (limited to 'src/syncServer.cpp')
-rw-r--r-- | src/syncServer.cpp | 41 |
1 files changed, 20 insertions, 21 deletions
diff --git a/src/syncServer.cpp b/src/syncServer.cpp index b2e4cf8..62b2cff 100644 --- a/src/syncServer.cpp +++ b/src/syncServer.cpp @@ -2,40 +2,39 @@ //using asio::ip::tcp; -SyncServer::SyncServer(asio::io_service& io_service, asio::ip::tcp::endpoint tcp_endpoint ) +SyncServer::SyncServer(boost::asio::io_service& io_service, boost::asio::ip::tcp::endpoint tcp_endpoint ) : acceptor_(io_service, tcp_endpoint) { - start_accept(); + start_accept(); } void SyncServer::start_accept() { - Lock lock(mutex_); - SyncTcpConnection::pointer new_connection = - SyncTcpConnection::create(acceptor_.io_service()); + Lock lock(mutex_); + SyncTcpConnection::pointer new_connection = + SyncTcpConnection::create(acceptor_.io_service()); conns_.push_back(new_connection); - - acceptor_.async_accept(new_connection->socket(), - boost::bind(&SyncServer::handle_accept, this, new_connection, - asio::placeholders::error)); + + acceptor_.async_accept(new_connection->socket(), + boost::bind(&SyncServer::handle_accept, this, new_connection, + boost::asio::placeholders::error)); } void SyncServer::send(std::string message) { - Lock lock(mutex_); -for(std::list<SyncTcpConnection::pointer>::iterator it = conns_.begin() ;it != conns_.end(); ++it) { - (*it)->Send(message); - } - + Lock lock(mutex_); + for(std::list<SyncTcpConnection::pointer>::iterator it = conns_.begin() ;it != conns_.end(); ++it) { + (*it)->Send(message); + } } void SyncServer::handle_accept(SyncTcpConnection::pointer new_connection, - const asio::error_code& error) + const boost::system::error_code& error) { - if (!error) - { - new_connection->onConnect=onConnect; - new_connection->start(); - start_accept(); - } + if (!error) + { + new_connection->onConnect=onConnect; + new_connection->start(); + start_accept(); + } } |