diff options
author | krasnobaev <krasnobaev@yandex-team.ru> | 2022-02-10 16:50:19 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:50:19 +0300 |
commit | 408b62b8b2bb0540f9251bb682b01b4d585d3754 (patch) | |
tree | 4409f4cc2667ddc58bf75acb65ae7139af4fbb9d /library/cpp/grpc/client/grpc_common.h | |
parent | db222959b3748242024c781f563f31a342492476 (diff) | |
download | ydb-408b62b8b2bb0540f9251bb682b01b4d585d3754.tar.gz |
Restoring authorship annotation for <krasnobaev@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/grpc/client/grpc_common.h')
-rw-r--r-- | library/cpp/grpc/client/grpc_common.h | 26 |
1 files changed, 13 insertions, 13 deletions
diff --git a/library/cpp/grpc/client/grpc_common.h b/library/cpp/grpc/client/grpc_common.h index ffcdafe045..35faabfca5 100644 --- a/library/cpp/grpc/client/grpc_common.h +++ b/library/cpp/grpc/client/grpc_common.h @@ -3,7 +3,7 @@ #include <grpc++/grpc++.h> #include <grpc++/resource_quota.h> -#include <util/datetime/base.h> +#include <util/datetime/base.h> #include <unordered_map> #include <util/generic/string.h> @@ -20,7 +20,7 @@ struct TGRpcClientConfig { ui32 MaxInFlight = 0; bool EnableSsl = false; TString SslCaCert; //Implicitly enables Ssl if not empty - grpc_compression_algorithm CompressionAlgoritm = GRPC_COMPRESS_NONE; + grpc_compression_algorithm CompressionAlgoritm = GRPC_COMPRESS_NONE; ui64 MemQuota = 0; std::unordered_map<TString, TString> StringChannelParams; std::unordered_map<TString, int> IntChannelParams; @@ -34,7 +34,7 @@ struct TGRpcClientConfig { TGRpcClientConfig& operator=(TGRpcClientConfig&&) = default; TGRpcClientConfig(const TString& locator, TDuration timeout = TDuration::Max(), - ui64 maxMessageSize = DEFAULT_GRPC_MESSAGE_SIZE_LIMIT, ui32 maxInFlight = 0, TString caCert = "", + ui64 maxMessageSize = DEFAULT_GRPC_MESSAGE_SIZE_LIMIT, ui32 maxInFlight = 0, TString caCert = "", grpc_compression_algorithm compressionAlgorithm = GRPC_COMPRESS_NONE, bool enableSsl = false) : Locator(locator) , Timeout(timeout) @@ -42,7 +42,7 @@ struct TGRpcClientConfig { , MaxInFlight(maxInFlight) , EnableSsl(enableSsl) , SslCaCert(caCert) - , CompressionAlgoritm(compressionAlgorithm) + , CompressionAlgoritm(compressionAlgorithm) {} }; @@ -50,16 +50,16 @@ inline std::shared_ptr<grpc::ChannelInterface> CreateChannelInterface(const TGRp grpc::ChannelArguments args; args.SetMaxReceiveMessageSize(config.MaxInboundMessageSize ? config.MaxInboundMessageSize : config.MaxMessageSize); args.SetMaxSendMessageSize(config.MaxOutboundMessageSize ? config.MaxOutboundMessageSize : config.MaxMessageSize); - args.SetCompressionAlgorithm(config.CompressionAlgoritm); - - for (const auto& kvp: config.StringChannelParams) { - args.SetString(kvp.first, kvp.second); - } - - for (const auto& kvp: config.IntChannelParams) { - args.SetInt(kvp.first, kvp.second); - } + args.SetCompressionAlgorithm(config.CompressionAlgoritm); + for (const auto& kvp: config.StringChannelParams) { + args.SetString(kvp.first, kvp.second); + } + + for (const auto& kvp: config.IntChannelParams) { + args.SetInt(kvp.first, kvp.second); + } + if (config.MemQuota) { grpc::ResourceQuota quota; quota.Resize(config.MemQuota); |