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

5 files changed, 28 insertions, 28 deletions

diff --git a/library/cpp/actors/http/http_proxy.cpp b/library/cpp/actors/http/http_proxy.cpp
index 36c6855d93..4b57a8453d 100644
--- a/library/cpp/actors/http/http_proxy.cpp
+++ b/library/cpp/actors/http/http_proxy.cpp
@@ -1,4 +1,4 @@
-#include <library/cpp/actors/core/events.h>
+#include <library/cpp/actors/core/events.h> 
 #include <library/cpp/monlib/metrics/metric_registry.h>
 #include "http_proxy.h"
 
@@ -43,19 +43,19 @@ protected:
             HFunc(TEvHttpProxy::TEvHttpConnectionClosed, Handle);
             HFunc(TEvHttpProxy::TEvResolveHostRequest, Handle);
             HFunc(TEvHttpProxy::TEvReportSensors, Handle);
-            HFunc(NActors::TEvents::TEvPoison, Handle);
+            HFunc(NActors::TEvents::TEvPoison, Handle); 
         }
     }
 
-    void PassAway() override {
-        Send(Poller, new NActors::TEvents::TEvPoisonPill());
+    void PassAway() override { 
+        Send(Poller, new NActors::TEvents::TEvPoisonPill()); 
         for (const NActors::TActorId& connection : Connections) {
-            Send(connection, new NActors::TEvents::TEvPoisonPill());
+            Send(connection, new NActors::TEvents::TEvPoisonPill()); 
         }
         for (const NActors::TActorId& acceptor : Acceptors) {
-            Send(acceptor, new NActors::TEvents::TEvPoisonPill());
+            Send(acceptor, new NActors::TEvents::TEvPoisonPill()); 
         }
-        NActors::TActorBootstrapped<THttpProxy>::PassAway();
+        NActors::TActorBootstrapped<THttpProxy>::PassAway(); 
     }
 
     void Handle(TEvHttpProxy::TEvHttpIncomingRequest::TPtr event, const NActors::TActorContext& ctx) {
@@ -200,10 +200,10 @@ protected:
                               NMonitoring::ExplicitHistogram({1, 5, 10, 50, 100, 500, 1000, 5000, 10000, 30000, 60000}))->Record(sensors.Time.MilliSeconds());
     }
 
-    void Handle(NActors::TEvents::TEvPoison::TPtr, const NActors::TActorContext&) {
-        PassAway();
-    }
-
+    void Handle(NActors::TEvents::TEvPoison::TPtr, const NActors::TActorContext&) { 
+        PassAway(); 
+    } 
+ 
     NActors::TActorId Poller;
     TVector<TActorId> Acceptors;
 
diff --git a/library/cpp/streams/lz/lz.cpp b/library/cpp/streams/lz/lz.cpp
index b65bb3ed96..de090a257c 100644
--- a/library/cpp/streams/lz/lz.cpp
+++ b/library/cpp/streams/lz/lz.cpp
@@ -3,7 +3,7 @@
 #include <util/system/yassert.h>
 #include <util/system/byteorder.h>
 #include <util/memory/addstorage.h>
-#include <util/generic/buffer.h>
+#include <util/generic/buffer.h> 
 #include <util/generic/utility.h>
 #include <util/generic/singleton.h>
 #include <util/generic/yexception.h>
@@ -193,8 +193,8 @@ public:
         , Version_(CheckVer(Load<ui32>()))
         , BlockSize_(Load<ui16>())
         , OutBufSize_(TDecompressor::Hint(BlockSize_))
-        , Tmp_(2 * OutBufSize_)
-        , In_(Tmp_.Data())
+        , Tmp_(2 * OutBufSize_) 
+        , In_(Tmp_.Data()) 
         , Out_(In_ + OutBufSize_)
     {
         this->InitFromStream(Slave_);
@@ -237,9 +237,9 @@ public:
         TMemoryInput header(tmp, sizeof(tmp));
 
         const ui16 len = GLoad<ui16>(&header);
-        if (len > Tmp_.Capacity()) {
-            ythrow TDecompressorError() << "invalid len inside block header";
-        }
+        if (len > Tmp_.Capacity()) { 
+            ythrow TDecompressorError() << "invalid len inside block header"; 
+        } 
         const ui8 compressed = GLoad<ui8>(&header);
 
         if (compressed > 1) {
@@ -271,7 +271,7 @@ protected:
     const ui32 Version_;
     const ui16 BlockSize_;
     const size_t OutBufSize_;
-    TBuffer Tmp_;
+    TBuffer Tmp_; 
     char* In_;
     char* Out_;
 };
diff --git a/library/cpp/streams/lz/lz_ut.cpp b/library/cpp/streams/lz/lz_ut.cpp
index 6876f070fc..5949f397c1 100644
--- a/library/cpp/streams/lz/lz_ut.cpp
+++ b/library/cpp/streams/lz/lz_ut.cpp
@@ -275,13 +275,13 @@ Y_UNIT_TEST_SUITE(TLzTest) {
 
         UNIT_ASSERT_EQUAL(is->ReadAll(), "123456789");
     }
-
-    Y_UNIT_TEST(TestYQ609) {
-        auto data = NResource::Find("/yq_609.data");
-
-        TMemoryInput input(data.Data(), data.Size());
-
-        TLz4Decompress d(&input);
-        UNIT_ASSERT_EXCEPTION(d.ReadAll(), TDecompressorError);
-    }
+ 
+    Y_UNIT_TEST(TestYQ609) { 
+        auto data = NResource::Find("/yq_609.data"); 
+ 
+        TMemoryInput input(data.Data(), data.Size()); 
+ 
+        TLz4Decompress d(&input); 
+        UNIT_ASSERT_EXCEPTION(d.ReadAll(), TDecompressorError); 
+    } 
 }
diff --git a/library/cpp/streams/lz/ut/ya.make b/library/cpp/streams/lz/ut/ya.make
index 18288c8ac9..ca35b53f10 100644
--- a/library/cpp/streams/lz/ut/ya.make
+++ b/library/cpp/streams/lz/ut/ya.make
@@ -8,7 +8,7 @@ OWNER(
 RESOURCE(
     random.data /random.data
     request.data /request.data
-    yq_609.data /yq_609.data
+    yq_609.data /yq_609.data 
 )
 
 SRCS(
diff --git a/library/cpp/streams/lz/ut/yq_609.data b/library/cpp/streams/lz/ut/yq_609.data
index 9694b0c97f..144f4b4cc7 100644
--- a/library/cpp/streams/lz/ut/yq_609.data
+++ b/library/cpp/streams/lz/ut/yq_609.data