diff options
author | dvshkurko <dvshkurko@yandex-team.ru> | 2022-02-10 16:45:51 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:45:51 +0300 |
commit | 321ee9bce31ec6e238be26dbcbe539cffa2c3309 (patch) | |
tree | 14407a2757cbf29eb97e266b7f07e851f971000c /contrib/libs/grpc/src/cpp/common/channel_arguments.cc | |
parent | 2f6ca198245aeffd5e2d82b65927c2465b68b4f5 (diff) | |
download | ydb-321ee9bce31ec6e238be26dbcbe539cffa2c3309.tar.gz |
Restoring authorship annotation for <dvshkurko@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'contrib/libs/grpc/src/cpp/common/channel_arguments.cc')
-rw-r--r-- | contrib/libs/grpc/src/cpp/common/channel_arguments.cc | 36 |
1 files changed, 18 insertions, 18 deletions
diff --git a/contrib/libs/grpc/src/cpp/common/channel_arguments.cc b/contrib/libs/grpc/src/cpp/common/channel_arguments.cc index 5a5dd91b5e..63232a5129 100644 --- a/contrib/libs/grpc/src/cpp/common/channel_arguments.cc +++ b/contrib/libs/grpc/src/cpp/common/channel_arguments.cc @@ -31,7 +31,7 @@ namespace grpc { ChannelArguments::ChannelArguments() { // This will be ignored if used on the server side. - SetString(GRPC_ARG_PRIMARY_USER_AGENT_STRING, "grpc-c++/" + grpc::Version()); + SetString(GRPC_ARG_PRIMARY_USER_AGENT_STRING, "grpc-c++/" + grpc::Version()); } ChannelArguments::ChannelArguments(const ChannelArguments& other) @@ -39,26 +39,26 @@ ChannelArguments::ChannelArguments(const ChannelArguments& other) args_.reserve(other.args_.size()); auto list_it_dst = strings_.begin(); auto list_it_src = other.strings_.begin(); - for (const auto& a : other.args_) { + for (const auto& a : other.args_) { grpc_arg ap; - ap.type = a.type; - GPR_ASSERT(list_it_src->c_str() == a.key); + ap.type = a.type; + GPR_ASSERT(list_it_src->c_str() == a.key); ap.key = const_cast<char*>(list_it_dst->c_str()); ++list_it_src; ++list_it_dst; - switch (a.type) { + switch (a.type) { case GRPC_ARG_INTEGER: - ap.value.integer = a.value.integer; + ap.value.integer = a.value.integer; break; case GRPC_ARG_STRING: - GPR_ASSERT(list_it_src->c_str() == a.value.string); + GPR_ASSERT(list_it_src->c_str() == a.value.string); ap.value.string = const_cast<char*>(list_it_dst->c_str()); ++list_it_src; ++list_it_dst; break; case GRPC_ARG_POINTER: - ap.value.pointer = a.value.pointer; - ap.value.pointer.p = a.value.pointer.vtable->copy(ap.value.pointer.p); + ap.value.pointer = a.value.pointer; + ap.value.pointer.p = a.value.pointer.vtable->copy(ap.value.pointer.p); break; } args_.push_back(ap); @@ -67,9 +67,9 @@ ChannelArguments::ChannelArguments(const ChannelArguments& other) ChannelArguments::~ChannelArguments() { grpc_core::ExecCtx exec_ctx; - for (auto& arg : args_) { - if (arg.type == GRPC_ARG_POINTER) { - arg.value.pointer.vtable->destroy(arg.value.pointer.p); + for (auto& arg : args_) { + if (arg.type == GRPC_ARG_POINTER) { + arg.value.pointer.vtable->destroy(arg.value.pointer.p); } } } @@ -95,12 +95,12 @@ void ChannelArguments::SetSocketMutator(grpc_socket_mutator* mutator) { grpc_arg mutator_arg = grpc_socket_mutator_to_arg(mutator); bool replaced = false; grpc_core::ExecCtx exec_ctx; - for (auto& arg : args_) { - if (arg.type == mutator_arg.type && + for (auto& arg : args_) { + if (arg.type == mutator_arg.type && TString(arg.key) == TString(mutator_arg.key)) { GPR_ASSERT(!replaced); - arg.value.pointer.vtable->destroy(arg.value.pointer.p); - arg.value.pointer = mutator_arg.value.pointer; + arg.value.pointer.vtable->destroy(arg.value.pointer.p); + arg.value.pointer = mutator_arg.value.pointer; replaced = true; } } @@ -123,13 +123,13 @@ void ChannelArguments::SetUserAgentPrefix( } bool replaced = false; auto strings_it = strings_.begin(); - for (auto& arg : args_) { + for (auto& arg : args_) { ++strings_it; if (arg.type == GRPC_ARG_STRING) { if (TString(arg.key) == GRPC_ARG_PRIMARY_USER_AGENT_STRING) { GPR_ASSERT(arg.value.string == strings_it->c_str()); *(strings_it) = user_agent_prefix + " " + arg.value.string; - arg.value.string = const_cast<char*>(strings_it->c_str()); + arg.value.string = const_cast<char*>(strings_it->c_str()); replaced = true; break; } |