diff options
author | spuchin <spuchin@yandex-team.ru> | 2022-02-10 16:48:16 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:48:16 +0300 |
commit | aab7e440a1750bc0841b355dcc4f388f31e5f5e3 (patch) | |
tree | c4ea3bd0ac108e34c329b483ba6ce11e25dfd005 /library/cpp/grpc/server/grpc_request.h | |
parent | 47dc960d070b29aa93972d1d49088393af89383f (diff) | |
download | ydb-aab7e440a1750bc0841b355dcc4f388f31e5f5e3.tar.gz |
Restoring authorship annotation for <spuchin@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/grpc/server/grpc_request.h')
-rw-r--r-- | library/cpp/grpc/server/grpc_request.h | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/library/cpp/grpc/server/grpc_request.h b/library/cpp/grpc/server/grpc_request.h index 5bd8d3902b..851fe11583 100644 --- a/library/cpp/grpc/server/grpc_request.h +++ b/library/cpp/grpc/server/grpc_request.h @@ -180,13 +180,13 @@ public: return AuthState_; } - void Reply(NProtoBuf::Message* resp, ui32 status) override { - ResponseStatus = status; + void Reply(NProtoBuf::Message* resp, ui32 status) override { + ResponseStatus = status; WriteDataOk(resp); } - void Reply(grpc::ByteBuffer* resp, ui32 status) override { - ResponseStatus = status; + void Reply(grpc::ByteBuffer* resp, ui32 status) override { + ResponseStatus = status; WriteByteDataOk(resp); } @@ -427,8 +427,8 @@ private: ok ? "true" : "false", this->Context.peer().c_str()); //PrintBackTrace(); DecRequest(); - Counters_->FinishProcessing(RequestSize, ResponseSize, ok, ResponseStatus, - TDuration::Seconds(RequestTimer.Passed())); + Counters_->FinishProcessing(RequestSize, ResponseSize, ok, ResponseStatus, + TDuration::Seconds(RequestTimer.Passed())); return false; } @@ -437,8 +437,8 @@ private: ok ? "true" : "false", this->Context.peer().c_str()); if (!SkipUpdateCountersOnError) { DecRequest(); - Counters_->FinishProcessing(RequestSize, ResponseSize, ok, ResponseStatus, - TDuration::Seconds(RequestTimer.Passed())); + Counters_->FinishProcessing(RequestSize, ResponseSize, ok, ResponseStatus, + TDuration::Seconds(RequestTimer.Passed())); } return false; } @@ -498,7 +498,7 @@ private: TOnNextReply NextReplyCb_; ui32 RequestSize = 0; ui32 ResponseSize = 0; - ui32 ResponseStatus = 0; + ui32 ResponseStatus = 0; THPTimer RequestTimer; TAuthState AuthState_ = 0; bool RequestRegistered_ = false; |