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

6 files changed, 18 insertions, 18 deletions

diff --git a/library/cpp/http/io/compression.h b/library/cpp/http/io/compression.h
index f16c4a18eb..3287c6f34c 100644
--- a/library/cpp/http/io/compression.h
+++ b/library/cpp/http/io/compression.h
@@ -2,7 +2,7 @@
 
 #include "stream.h"
 
-#include <util/generic/deque.h>
+#include <util/generic/deque.h> 
 #include <util/generic/hash.h>
 
 class TCompressionCodecFactory {
@@ -44,7 +44,7 @@ private:
         TEncoderConstructor Encoder;
     };
 
-    TDeque<TString> Strings_;
+    TDeque<TString> Strings_; 
     THashMap<TStringBuf, TCodec> Codecs_;
     TVector<TStringBuf> BestCodecs_;
 };
diff --git a/library/cpp/http/misc/parsed_request.cpp b/library/cpp/http/misc/parsed_request.cpp
index e332a24e91..7f322ce0ea 100644
--- a/library/cpp/http/misc/parsed_request.cpp
+++ b/library/cpp/http/misc/parsed_request.cpp
@@ -2,7 +2,7 @@
 
 #include <util/string/strip.h>
 #include <util/generic/yexception.h>
-#include <util/string/cast.h>
+#include <util/string/cast.h> 
 
 static inline TStringBuf StripLeft(const TStringBuf& s) noexcept {
     const char* b = s.begin();
diff --git a/library/cpp/http/server/http.cpp b/library/cpp/http/server/http.cpp
index 128583bdd7..48498e6b8b 100644
--- a/library/cpp/http/server/http.cpp
+++ b/library/cpp/http/server/http.cpp
@@ -17,7 +17,7 @@
 #include <util/system/mutex.h>
 #include <util/system/pipe.h>
 #include <util/system/thread.h>
-#include <util/thread/factory.h>
+#include <util/thread/factory.h> 
 
 #include <cerrno>
 #include <cstring>
diff --git a/library/cpp/http/server/http.h b/library/cpp/http/server/http.h
index b292d38f27..517fcf9eb2 100644
--- a/library/cpp/http/server/http.h
+++ b/library/cpp/http/server/http.h
@@ -3,14 +3,14 @@
 #include "conn.h"
 #include "options.h"
 
-#include <util/thread/pool.h>
+#include <util/thread/pool.h> 
 #include <library/cpp/http/io/stream.h>
 #include <util/memory/blob.h>
 #include <util/generic/ptr.h>
 #include <util/generic/vector.h>
 #include <util/system/atomic.h>
 
-class IThreadFactory;
+class IThreadFactory; 
 class TClientRequest;
 class TClientConnection;
 
@@ -62,7 +62,7 @@ public:
     };
 
     typedef THttpServerOptions TOptions;
-    typedef TSimpleSharedPtr<IThreadPool> TMtpQueueRef;
+    typedef TSimpleSharedPtr<IThreadPool> TMtpQueueRef; 
 
     THttpServer(ICallBack* cb, const TOptions& options = TOptions(), IThreadFactory* pool = nullptr);
     THttpServer(ICallBack* cb, TMtpQueueRef mainWorkers, TMtpQueueRef failWorkers, const TOptions& options = TOptions());
diff --git a/library/cpp/http/server/http_ut.cpp b/library/cpp/http/server/http_ut.cpp
index cc62bb988e..1199007496 100644
--- a/library/cpp/http/server/http_ut.cpp
+++ b/library/cpp/http/server/http_ut.cpp
@@ -289,7 +289,7 @@ Y_UNIT_TEST_SUITE(THttpServerTest) {
         bool Expect100Continue = false;
     };
 
-    class TFailingMtpQueue: public TSimpleThreadPool {
+    class TFailingMtpQueue: public TSimpleThreadPool { 
     private:
         bool FailOnAdd_ = false;
 
@@ -297,16 +297,16 @@ Y_UNIT_TEST_SUITE(THttpServerTest) {
         void SetFailOnAdd(bool fail = true) {
             FailOnAdd_ = fail;
         }
-        [[nodiscard]] bool Add(IObjectInQueue* pObj) override {
+        [[nodiscard]] bool Add(IObjectInQueue* pObj) override { 
             if (FailOnAdd_) {
                 return false;
             }
 
-            return TSimpleThreadPool::Add(pObj);
+            return TSimpleThreadPool::Add(pObj); 
         }
         TFailingMtpQueue() = default;
-        TFailingMtpQueue(IThreadFactory* pool)
-            : TSimpleThreadPool(pool)
+        TFailingMtpQueue(IThreadFactory* pool) 
+            : TSimpleThreadPool(pool) 
         {
         }
     };
@@ -434,9 +434,9 @@ Y_UNIT_TEST_SUITE(THttpServerTest) {
         THttpServer::TOptions options(port);
         options.EnableKeepAlive(true);
         options.EnableCompression(true);
-        using TFailingServerMtpQueue = TThreadPoolBinder<TFailingMtpQueue, THttpServer::ICallBack>;
-        THttpServer::TMtpQueueRef mainWorkers = new TFailingServerMtpQueue(&serverImpl, SystemThreadFactory());
-        THttpServer::TMtpQueueRef failWorkers = new TThreadPool(SystemThreadFactory());
+        using TFailingServerMtpQueue = TThreadPoolBinder<TFailingMtpQueue, THttpServer::ICallBack>; 
+        THttpServer::TMtpQueueRef mainWorkers = new TFailingServerMtpQueue(&serverImpl, SystemThreadFactory()); 
+        THttpServer::TMtpQueueRef failWorkers = new TThreadPool(SystemThreadFactory()); 
         THttpServer server(&serverImpl, mainWorkers, failWorkers, options);
 
         UNIT_ASSERT(server.Start());
@@ -703,7 +703,7 @@ Y_UNIT_TEST_SUITE(THttpServerTest) {
 
         for (bool keepAlive : trueFalse) {
             server.ResetCounters();
-            TVector<TAutoPtr<IThreadFactory::IThread>> threads;
+            TVector<TAutoPtr<IThreadFactory::IThread>> threads; 
 
             server.Busy(3);
             server.BusyThread();
@@ -715,7 +715,7 @@ Y_UNIT_TEST_SUITE(THttpServerTest) {
                     r->KeepAliveConnection = keepAlive;
                     r->Execute();
                 };
-                threads.push_back(SystemThreadFactory()->Run(func));
+                threads.push_back(SystemThreadFactory()->Run(func)); 
             }
 
             server.FreeThread(); // all threads get connection & go to processing
diff --git a/library/cpp/http/server/response.cpp b/library/cpp/http/server/response.cpp
index 52d64c91ce..b94a2f4482 100644
--- a/library/cpp/http/server/response.cpp
+++ b/library/cpp/http/server/response.cpp
@@ -2,7 +2,7 @@
 
 #include <util/stream/output.h>
 #include <util/stream/mem.h>
-#include <util/string/cast.h>
+#include <util/string/cast.h> 
 
 THttpResponse& THttpResponse::AddMultipleHeaders(const THttpHeaders& headers) {
     for (THttpHeaders::TConstIterator i = headers.Begin(); i != headers.End(); ++i) {