| | |
| | | #include "tcp_common.h" |
| | | |
| | | class NodeCenter; |
| | | class TcpServer : public IoService |
| | | class TcpServer |
| | | { |
| | | public: |
| | | typedef IoService::io_service_t io_service_t; |
| | | typedef std::shared_ptr<Synced<NodeCenter>> CenterPtr; |
| | | TcpServer(int port, CenterPtr pscenter); |
| | | ~TcpServer(); |
| | | TcpServer(io_service_t &io, int port, CenterPtr pscenter) : |
| | | io_(io), listener_(io_, tcp::endpoint(tcp::v6(), port)), pscenter_(pscenter) { Accept(); } |
| | | ~TcpServer() { listener_.close(); } |
| | | |
| | | private: |
| | | virtual void OnStop(); |
| | | io_service_t &io_; |
| | | void Accept(); |
| | | tcp::acceptor listener_; |
| | | CenterPtr pscenter_; |