Restoring authorship annotation for <[email protected]>. Commit 1 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 0b6c36c84cc..e8f0ca2179e 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 5bd8d3902b5..851fe115831 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 fcfce1c181a..740c3c4fdd9 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;