Restoring authorship annotation for <spuchin@yandex-team.ru>. Commit 2 of 2.

3 files changed, 16 insertions, 16 deletions

diff --git a/library/cpp/grpc/server/grpc_counters.h b/library/cpp/grpc/server/grpc_counters.h
index e8f0ca2179..0b6c36c84c 100644
--- a/library/cpp/grpc/server/grpc_counters.h
+++ b/library/cpp/grpc/server/grpc_counters.h
@@ -97,11 +97,11 @@ public:
         *InflyRequestBytes += requestSize;
     }
 
-    void FinishProcessing(ui32 requestSize, ui32 responseSize, bool ok, ui32 status, 
-        TDuration requestDuration) override 
-    { 
-        Y_UNUSED(status); 
- 
+    void FinishProcessing(ui32 requestSize, ui32 responseSize, bool ok, ui32 status,
+        TDuration requestDuration) override
+    {
+        Y_UNUSED(status);
+
         InflyCounter->Dec();
         *InflyRequestBytes -= requestSize;
         *ResponseBytes += responseSize;
diff --git a/library/cpp/grpc/server/grpc_request.h b/library/cpp/grpc/server/grpc_request.h
index 851fe11583..5bd8d3902b 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;
diff --git a/library/cpp/grpc/server/grpc_request_base.h b/library/cpp/grpc/server/grpc_request_base.h
index 740c3c4fdd..fcfce1c181 100644
--- a/library/cpp/grpc/server/grpc_request_base.h
+++ b/library/cpp/grpc/server/grpc_request_base.h
@@ -58,11 +58,11 @@ public:
 
     //! Send common response (The request shoult be created for protobuf response type)
     //! Implementation can swap protobuf message
-    virtual void Reply(NProtoBuf::Message* resp, ui32 status = 0) = 0; 
+    virtual void Reply(NProtoBuf::Message* resp, ui32 status = 0) = 0;
 
     //! Send serialised response (The request shoult be created for bytes response type)
     //! Implementation can swap ByteBuffer
-    virtual void Reply(grpc::ByteBuffer* resp, ui32 status = 0) = 0; 
+    virtual void Reply(grpc::ByteBuffer* resp, ui32 status = 0) = 0;
 
     //! Send grpc UNAUTHENTICATED status
     virtual void ReplyUnauthenticated(const TString& in) = 0;