Restoring authorship annotation for Sergey Polovko <sergey@polovko.me>. Commit 2 of 2.

1 files changed, 30 insertions, 30 deletions

diff --git a/library/cpp/grpc/server/grpc_async_ctx_base.h b/library/cpp/grpc/server/grpc_async_ctx_base.h
index 65341fa1ad..51356d4ce5 100644
--- a/library/cpp/grpc/server/grpc_async_ctx_base.h
+++ b/library/cpp/grpc/server/grpc_async_ctx_base.h
@@ -5,17 +5,17 @@
 #include <util/generic/vector.h>
 #include <util/generic/string.h>
 #include <util/system/yassert.h>
-#include <util/generic/set.h> 
+#include <util/generic/set.h>
 
 #include <grpc++/server.h>
 #include <grpc++/server_context.h>
 
 #include <chrono>
 
-namespace NGrpc { 
+namespace NGrpc {
 
 template<typename TService>
-class TBaseAsyncContext: public ICancelableContext { 
+class TBaseAsyncContext: public ICancelableContext {
 public:
     TBaseAsyncContext(typename TService::TCurrentGRpcService::AsyncService* service, grpc::ServerCompletionQueue* cq)
         : Service(service)
@@ -29,44 +29,44 @@ public:
 
     TInstant Deadline() const {
         // The timeout transferred in "grpc-timeout" header [1] and calculated from the deadline
-        // right before the request is getting to be send. 
-        // 1. https://github.com/grpc/grpc/blob/master/doc/PROTOCOL-HTTP2.md 
-        // 
+        // right before the request is getting to be send.
+        // 1. https://github.com/grpc/grpc/blob/master/doc/PROTOCOL-HTTP2.md
+        //
         // After this timeout calculated back to the deadline on the server side
         // using server grpc GPR_CLOCK_MONOTONIC time (raw_deadline() method).
         // deadline() method convert this to epoch related deadline GPR_CLOCK_REALTIME
         //
- 
+
         std::chrono::system_clock::time_point t = Context.deadline();
         if (t == std::chrono::system_clock::time_point::max()) {
             return TInstant::Max();
-        } 
+        }
         auto us = std::chrono::time_point_cast<std::chrono::microseconds>(t);
         return TInstant::MicroSeconds(us.time_since_epoch().count());
-    } 
- 
-    TSet<TStringBuf> GetPeerMetaKeys() const { 
-        TSet<TStringBuf> keys; 
-        for (const auto& [key, _]: Context.client_metadata()) { 
-            keys.emplace(key.data(), key.size()); 
-        } 
-        return keys; 
-    } 
- 
-    TVector<TStringBuf> GetPeerMetaValues(TStringBuf key) const { 
+    }
+
+    TSet<TStringBuf> GetPeerMetaKeys() const {
+        TSet<TStringBuf> keys;
+        for (const auto& [key, _]: Context.client_metadata()) {
+            keys.emplace(key.data(), key.size());
+        }
+        return keys;
+    }
+
+    TVector<TStringBuf> GetPeerMetaValues(TStringBuf key) const {
         const auto& clientMetadata = Context.client_metadata();
-        const auto range = clientMetadata.equal_range(grpc::string_ref{key.data(), key.size()}); 
-        if (range.first == range.second) { 
-            return {}; 
-        } 
- 
-        TVector<TStringBuf> values; 
-        values.reserve(std::distance(range.first, range.second)); 
- 
+        const auto range = clientMetadata.equal_range(grpc::string_ref{key.data(), key.size()});
+        if (range.first == range.second) {
+            return {};
+        }
+
+        TVector<TStringBuf> values;
+        values.reserve(std::distance(range.first, range.second));
+
         for (auto it = range.first; it != range.second; ++it) {
-            values.emplace_back(it->second.data(), it->second.size()); 
+            values.emplace_back(it->second.data(), it->second.size());
         }
-        return values; 
+        return values;
     }
 
     grpc_compression_level GetCompressionLevel() const {
@@ -91,4 +91,4 @@ protected:
     grpc::ServerContext Context;
 };
 
-} // namespace NGrpc 
+} // namespace NGrpc