src/syncServer.cpp

   1 #include "syncServer.h"
   2
   3 //using asio::ip::tcp;
   4
   5 SyncServer::SyncServer(boost::asio::io_service& io_service, boost::asio::ip::tcp::endpoint tcp_endpoint )
   6     : acceptor_(io_service, tcp_endpoint)
   7 {
   8   start_accept();
   9 }
  10
  11 void SyncServer::start_accept()
  12 {
  13   Lock lock(mutex_);
  14   SyncTcpConnection::pointer new_connection =
  15     SyncTcpConnection::create(acceptor_.io_service());
  16   conns_.push_back(new_connection);
  17
  18   acceptor_.async_accept(new_connection->socket(),
  19                          boost::bind(&SyncServer::handle_accept, this, new_connection,
  20                                      boost::asio::placeholders::error));
  21 }
  22
  23 void SyncServer::send(std::string message)
  24 {
  25   Lock lock(mutex_);
  26   for(std::list<SyncTcpConnection::pointer>::iterator it = conns_.begin() ;it != conns_.end(); ++it) {
  27     (*it)->Send(message);
  28   }
  29 }
  30
  31 void  SyncServer::handle_accept(SyncTcpConnection::pointer new_connection,
  32     const boost::system::error_code& error)
  33 {
  34   if (!error)
  35   {
  36     new_connection->onConnect=onConnect;
  37     new_connection->start();
  38     start_accept();
  39   }
  40 }