summaryrefslogtreecommitdiff
path: root/src/syncServer.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/syncServer.cpp')
-rw-r--r--src/syncServer.cpp41
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();
+ }
}