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

build/rules/yt.policy

@@ -1,6 +1,6 @@
 ALLOW yt -> yt/yt/server
 
 DENY .* -> yt/yt/server
-
-ALLOW mapreduce/yt/experiments -> mapreduce/yt/experiments
-DENY .* -> mapreduce/yt/experiments
+ 
+ALLOW mapreduce/yt/experiments -> mapreduce/yt/experiments 
+DENY .* -> mapreduce/yt/experiments 

contrib/libs/protobuf/src/google/protobuf/messagext.cc

@@ -74,33 +74,33 @@ bool SerializeToZeroCopyStreamSeq(const Message* msg, io::ZeroCopyOutputStream*
 }
 
 
-int TInputStreamProxy::Read(void* buffer, int size) {
-    try {
-        return (int)mSlave->Read(buffer, (size_t)size);
-    } catch (const yexception& e) {
-        GOOGLE_LOG(ERROR) << e.what();
-    } catch (...) {
-        GOOGLE_LOG(ERROR) << "unknown exception caught";
-    }
-    TErrorState::SetError();
-    return -1;
-}
-
-
-bool TOutputStreamProxy::Write(const void* buffer, int size) {
-    try {
-        mSlave->Write(buffer, (size_t)size);
-        return true;
-    } catch (const yexception& e) {
-        GOOGLE_LOG(ERROR) << e.what();
-    } catch (...) {
-        GOOGLE_LOG(ERROR) << "unknown exception caught";
-    }
-    TErrorState::SetError();
-    return false;
-}
-
-
+int TInputStreamProxy::Read(void* buffer, int size) { 
+    try { 
+        return (int)mSlave->Read(buffer, (size_t)size); 
+    } catch (const yexception& e) { 
+        GOOGLE_LOG(ERROR) << e.what(); 
+    } catch (...) { 
+        GOOGLE_LOG(ERROR) << "unknown exception caught"; 
+    } 
+    TErrorState::SetError(); 
+    return -1; 
+} 
+
+ 
+bool TOutputStreamProxy::Write(const void* buffer, int size) { 
+    try { 
+        mSlave->Write(buffer, (size_t)size); 
+        return true; 
+    } catch (const yexception& e) { 
+        GOOGLE_LOG(ERROR) << e.what(); 
+    } catch (...) { 
+        GOOGLE_LOG(ERROR) << "unknown exception caught"; 
+    } 
+    TErrorState::SetError(); 
+    return false; 
+} 
+ 
+ 
 void TProtoSerializer::Save(IOutputStream* out, const Message& msg) {
     int size = msg.ByteSize();
     if (size > MaxSizeBytes) {

contrib/libs/protobuf/src/google/protobuf/messagext.h

@@ -67,7 +67,7 @@ class TInputStreamProxy: public io::CopyingInputStream, public TErrorState {
         {
         }
 
-        virtual int Read(void* buffer, int size);
+        virtual int Read(void* buffer, int size); 
 
     private:
         IInputStream* mSlave;
@@ -80,7 +80,7 @@ class TOutputStreamProxy: public io::CopyingOutputStream, public TErrorState {
         {
         }
 
-        virtual bool Write(const void* buffer, int size);
+        virtual bool Write(const void* buffer, int size); 
 
     private:
         IOutputStream* mSlave;

library/cpp/digest/md5/md5.h

@@ -68,8 +68,8 @@ public:
 
 private:
     void UpdatePart(TArrayRef<const ui8> data);
-
-private:
+ 
+private: 
     ui8 BufferSize;  /* size of buffer */
     ui8 Buffer[64];  /* input buffer */
     ui32 State[4];   /* state (ABCD) */

library/cpp/digest/md5/md5_medium_ut.cpp

@@ -5,21 +5,21 @@
 Y_UNIT_TEST_SUITE(TMD5MediumTest) {
     Y_UNIT_TEST(TestOverflow) {
         if (sizeof(size_t) > sizeof(unsigned int)) {
-            const size_t maxUi32 = (size_t)Max<unsigned int>();
+            const size_t maxUi32 = (size_t)Max<unsigned int>(); 
             TArrayHolder<char> buf(new char[maxUi32]);
 
-            memset(buf.Get(), 0, maxUi32);
+            memset(buf.Get(), 0, maxUi32); 
 
-            MD5 r;
-            for (int i = 0; i < 5; ++i) {
-                r.Update(buf.Get(), maxUi32);
-            }
+            MD5 r; 
+            for (int i = 0; i < 5; ++i) { 
+                r.Update(buf.Get(), maxUi32); 
+            } 
 
-            char rs[33];
-            TString s(r.End(rs));
-            s.to_lower();
+            char rs[33]; 
+            TString s(r.End(rs)); 
+            s.to_lower(); 
 
-            UNIT_ASSERT_VALUES_EQUAL(s, "34a5a7ed4f0221310084e21a1e599659");
+            UNIT_ASSERT_VALUES_EQUAL(s, "34a5a7ed4f0221310084e21a1e599659"); 
         }
     }
 }

library/cpp/digest/md5/medium_ut/ya.make

@@ -1,16 +1,16 @@
 UNITTEST_FOR(library/cpp/digest/md5)
 
-SIZE(MEDIUM)
-
-TIMEOUT(120)
+SIZE(MEDIUM) 
 
+TIMEOUT(120) 
+ 
 OWNER(
     pg
     g:util
 )
 
 SRCS(
-    md5_medium_ut.cpp
+    md5_medium_ut.cpp 
 )
 
 REQUIREMENTS(ram:10)

library/cpp/digest/ya.make

@@ -9,7 +9,7 @@ RECURSE(
     lower_case/ut
     md5
     md5/ut
-    md5/medium_ut
+    md5/medium_ut 
     md5/bench
     murmur
     murmur/ut

library/cpp/http/io/chunk.cpp

@@ -1,7 +1,7 @@
 #include "chunk.h"
 
-#include "headers.h"
-
+#include "headers.h" 
+ 
 #include <util/string/cast.h>
 #include <util/generic/utility.h>
 #include <util/generic/yexception.h>
@@ -52,13 +52,13 @@ class TChunkedInput::TImpl {
 public:
     inline TImpl(IInputStream* slave, TMaybe<THttpHeaders>* trailers)
         : Slave_(slave)
-        , Trailers_(trailers)
+        , Trailers_(trailers) 
         , Pending_(0)
         , LastChunkReaded_(false)
     {
-        if (Trailers_) {
-            Trailers_->Clear();
-        }
+        if (Trailers_) { 
+            Trailers_->Clear(); 
+        } 
     }
 
     inline ~TImpl() {
@@ -127,9 +127,9 @@ private:
             return true;
         }
 
-        if (Trailers_) {
-            Trailers_->ConstructInPlace(Slave_);
-        }
+        if (Trailers_) { 
+            Trailers_->ConstructInPlace(Slave_); 
+        } 
         LastChunkReaded_ = true;
 
         return false;
@@ -137,13 +137,13 @@ private:
 
 private:
     IInputStream* Slave_;
-    TMaybe<THttpHeaders>* Trailers_;
+    TMaybe<THttpHeaders>* Trailers_; 
     size_t Pending_;
     bool LastChunkReaded_;
 };
 
 TChunkedInput::TChunkedInput(IInputStream* slave, TMaybe<THttpHeaders>* trailers)
-    : Impl_(new TImpl(slave, trailers))
+    : Impl_(new TImpl(slave, trailers)) 
 {
 }
 

library/cpp/http/io/chunk.h

@@ -1,11 +1,11 @@
 #pragma once
 
 #include <util/stream/output.h>
-#include <util/generic/maybe.h>
+#include <util/generic/maybe.h> 
 #include <util/generic/ptr.h>
 
-class THttpHeaders;
-
+class THttpHeaders; 
+ 
 /// @addtogroup Streams_Chunked
 /// @{
 /// Ввод данных порциями.
@@ -13,8 +13,8 @@ class THttpHeaders;
 /// данные записаны в виде <длина блока><блок данных>.
 class TChunkedInput: public IInputStream {
 public:
-    /// Если передан указатель на trailers, то туда будут записаны HTTP trailer'ы (возможно пустые),
-    /// которые идут после чанков.
+    /// Если передан указатель на trailers, то туда будут записаны HTTP trailer'ы (возможно пустые), 
+    /// которые идут после чанков. 
     TChunkedInput(IInputStream* slave, TMaybe<THttpHeaders>* trailers = nullptr);
     ~TChunkedInput() override;
 

library/cpp/http/io/compression.h

@@ -15,7 +15,7 @@ public:
     static inline TCompressionCodecFactory& Instance() noexcept {
         return *SingletonWithPriority<TCompressionCodecFactory, 0>();
     }
-
+ 
     inline const TDecoderConstructor* FindDecoder(TStringBuf name) const {
         if (auto codec = Codecs_.FindPtr(name)) {
             return &codec->Decoder;