library/cpp/neh/tcp2.h


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
42
43
44

#pragma once

#include <util/datetime/base.h>
#include <util/system/defaults.h>

namespace NNeh {
    //global options
    struct TTcp2Options {
        //connect timeout
        static TDuration ConnectTimeout;

        //input buffer size
        static size_t InputBufferSize;

        //asio client threads
        static size_t AsioClientThreads;

        //asio server threads, - if == 0, use acceptor thread for read/parse incoming requests
        //esle use one thread for accepting + AsioServerThreads for process established tcp connections
        static size_t AsioServerThreads;

        //listen socket queue limit
        static int Backlog;

        //try call non block write to socket from client thread (for decrease latency)
        static bool ClientUseDirectWrite;

        //try call non block write to socket from client thread (for decrease latency)
        static bool ServerUseDirectWrite;

        //expecting receiving request data right after connect or inside receiving request data
        static TDuration ServerInputDeadline;

        //timelimit for sending response data
        static TDuration ServerOutputDeadline;

        //set option, - return false, if option name not recognized
        static bool Set(TStringBuf name, TStringBuf value);
    };

    class IProtocol;

    IProtocol* Tcp2Protocol();
}