aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/grpc/client/grpc_common.h
diff options
context:
space:
mode:
authorkrasnobaev <krasnobaev@yandex-team.ru>2022-02-10 16:50:19 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:50:19 +0300
commit408b62b8b2bb0540f9251bb682b01b4d585d3754 (patch)
tree4409f4cc2667ddc58bf75acb65ae7139af4fbb9d /library/cpp/grpc/client/grpc_common.h
parentdb222959b3748242024c781f563f31a342492476 (diff)
downloadydb-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.h26
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);