/*
|
* =====================================================================================
|
*
|
* Filename: tcp_server.cpp
|
*
|
* Description:
|
*
|
* Version: 1.0
|
* Created: 2021年05月19日 15时05分33秒
|
* Revision: none
|
* Compiler: gcc
|
*
|
* Author: Li Chao (), lichao@aiotlink.com
|
* Organization:
|
*
|
* =====================================================================================
|
*/
|
|
#include "tcp_server.h"
|
#include "log.h"
|
#include "tcp_connection.h"
|
#include <chrono>
|
|
using namespace std::chrono_literals;
|
|
TcpServer::TcpServer(int port, CenterPtr pscenter) :
|
listener_(io(), tcp::endpoint(tcp::v6(), port)), pscenter_(pscenter)
|
{
|
Accept();
|
}
|
|
TcpServer::~TcpServer() { Stop(); }
|
|
void TcpServer::OnStop()
|
{
|
listener_.close();
|
}
|
|
void TcpServer::Accept()
|
{
|
listener_.async_accept([this](bserror_t ec, tcp::socket sock) {
|
if (!ec) {
|
LOG_INFO() << "server accept client";
|
TcpReply1::Create(std::move(sock), pscenter_);
|
}
|
Accept();
|
});
|
}
|
