diff options
| author | Anton Samokhvalov <pg83@yandex.ru> | 2022-02-10 16:45:17 +0300 |
|---|---|---|
| committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:45:17 +0300 |
| commit | d3a398281c6fd1d3672036cb2d63f842d2cb28c5 (patch) | |
| tree | dd4bd3ca0f36b817e96812825ffaf10d645803f2 /library/cpp/messagebus/config/session_config.h | |
| parent | 72cb13b4aff9bc9cf22e49251bc8fd143f82538f (diff) | |
| download | ydb-d3a398281c6fd1d3672036cb2d63f842d2cb28c5.tar.gz | |
Restoring authorship annotation for Anton Samokhvalov <pg83@yandex.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/messagebus/config/session_config.h')
| -rw-r--r-- | library/cpp/messagebus/config/session_config.h | 90 |
1 files changed, 45 insertions, 45 deletions
diff --git a/library/cpp/messagebus/config/session_config.h b/library/cpp/messagebus/config/session_config.h index db17018bbc..84753350a9 100644 --- a/library/cpp/messagebus/config/session_config.h +++ b/library/cpp/messagebus/config/session_config.h @@ -8,58 +8,58 @@ #include <util/generic/string.h> namespace NBus { -#define BUS_SESSION_CONFIG_MAP(XX, comma) \ - XX(Name, TString, "") \ - comma \ - XX(NumRetries, int, 0) comma \ - XX(RetryInterval, int, 1000) comma \ - XX(ReconnectWhenIdle, bool, false) comma \ - XX(MaxInFlight, i64, 1000) comma \ - XX(PerConnectionMaxInFlight, unsigned, 0) comma \ - XX(PerConnectionMaxInFlightBySize, unsigned, 0) comma \ - XX(MaxInFlightBySize, i64, -1) comma \ - XX(TotalTimeout, i64, 0) comma \ - XX(SendTimeout, i64, 0) comma \ - XX(ConnectTimeout, i64, 0) comma \ - XX(DefaultBufferSize, size_t, 10 * 1024) comma \ - XX(MaxBufferSize, size_t, 1024 * 1024) comma \ - XX(SocketRecvBufferSize, unsigned, 0) comma \ - XX(SocketSendBufferSize, unsigned, 0) comma \ - XX(SocketToS, int, -1) comma \ - XX(SendThreshold, size_t, 10 * 1024) comma \ - XX(Cork, TDuration, TDuration::Zero()) comma \ - XX(MaxMessageSize, unsigned, 26 << 20) comma \ - XX(TcpNoDelay, bool, false) comma \ - XX(TcpCork, bool, false) comma \ - XX(ExecuteOnMessageInWorkerPool, bool, true) comma \ - XX(ExecuteOnReplyInWorkerPool, bool, true) comma \ - XX(ReusePort, bool, false) comma \ - XX(ListenPort, unsigned, 0) /* TODO: server only */ +#define BUS_SESSION_CONFIG_MAP(XX, comma) \ + XX(Name, TString, "") \ + comma \ + XX(NumRetries, int, 0) comma \ + XX(RetryInterval, int, 1000) comma \ + XX(ReconnectWhenIdle, bool, false) comma \ + XX(MaxInFlight, i64, 1000) comma \ + XX(PerConnectionMaxInFlight, unsigned, 0) comma \ + XX(PerConnectionMaxInFlightBySize, unsigned, 0) comma \ + XX(MaxInFlightBySize, i64, -1) comma \ + XX(TotalTimeout, i64, 0) comma \ + XX(SendTimeout, i64, 0) comma \ + XX(ConnectTimeout, i64, 0) comma \ + XX(DefaultBufferSize, size_t, 10 * 1024) comma \ + XX(MaxBufferSize, size_t, 1024 * 1024) comma \ + XX(SocketRecvBufferSize, unsigned, 0) comma \ + XX(SocketSendBufferSize, unsigned, 0) comma \ + XX(SocketToS, int, -1) comma \ + XX(SendThreshold, size_t, 10 * 1024) comma \ + XX(Cork, TDuration, TDuration::Zero()) comma \ + XX(MaxMessageSize, unsigned, 26 << 20) comma \ + XX(TcpNoDelay, bool, false) comma \ + XX(TcpCork, bool, false) comma \ + XX(ExecuteOnMessageInWorkerPool, bool, true) comma \ + XX(ExecuteOnReplyInWorkerPool, bool, true) comma \ + XX(ReusePort, bool, false) comma \ + XX(ListenPort, unsigned, 0) /* TODO: server only */ - //////////////////////////////////////////////////////////////////// - /// \brief Configuration for client and server session - struct TBusSessionConfig { - BUS_SESSION_CONFIG_MAP(STRUCT_FIELD_GEN, ) + //////////////////////////////////////////////////////////////////// + /// \brief Configuration for client and server session + struct TBusSessionConfig { + BUS_SESSION_CONFIG_MAP(STRUCT_FIELD_GEN, ) - struct TSecret { - TDuration TimeoutPeriod; - TDuration StatusFlushPeriod; + struct TSecret { + TDuration TimeoutPeriod; + TDuration StatusFlushPeriod; - TSecret(); - }; + TSecret(); + }; - // secret options are available, but you shouldn't probably use them - TSecret Secret; + // secret options are available, but you shouldn't probably use them + TSecret Secret; - /// initialized with default settings - TBusSessionConfig(); + /// initialized with default settings + TBusSessionConfig(); - TString PrintToString() const; + TString PrintToString() const; - void ConfigureLastGetopt(NLastGetopt::TOpts&, const TString& prefix = "mb-"); - }; + void ConfigureLastGetopt(NLastGetopt::TOpts&, const TString& prefix = "mb-"); + }; - using TBusClientSessionConfig = TBusSessionConfig; - using TBusServerSessionConfig = TBusSessionConfig; + using TBusClientSessionConfig = TBusSessionConfig; + using TBusServerSessionConfig = TBusSessionConfig; } // NBus |