liuxiaolong
2021-07-20 58d904a328c0d849769b483e901a0be9426b8209
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
/*
 * =====================================================================================
 *
 *       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;
 
void TcpServer::Accept()
{
    listener_.async_accept([this](bserror_t ec, tcp::socket sock) {
        if (!ec) {
            LOG_TRACE() << "server accept client";
            TcpReply1::Create(std::move(sock), pscenter_);
            Accept();
        } else {
            // this is already destructed by now.
            if (ec.value() != ECANCELED) {
                LOG_WARNING() << "tcp server accept error: " << ec;
                Accept();
            }
        }
    });
}