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

3 files changed, 39 insertions, 39 deletions

diff --git a/library/cpp/messagebus/rain_check/http/client.cpp b/library/cpp/messagebus/rain_check/http/client.cpp
index 0d2d717cc89..5ef5ceeece2 100644
--- a/library/cpp/messagebus/rain_check/http/client.cpp
+++ b/library/cpp/messagebus/rain_check/http/client.cpp
@@ -10,8 +10,8 @@
 
 #include <util/generic/ptr.h>
 #include <util/generic/strbuf.h>
-#include <util/network/socket.h> 
-#include <util/stream/str.h> 
+#include <util/network/socket.h>
+#include <util/stream/str.h>
 
 namespace NRainCheck {
     class THttpCallback: public NNeh::IOnRecv {
@@ -66,11 +66,11 @@ namespace NRainCheck {
 
     void THttpClientService::SendPost(TString addr, const TString& data, const THttpHeaders& headers, THttpFuture* future) {
         Y_VERIFY(!!future, "future is NULL.");
- 
+
         TTaskRunnerBase* current = TTaskRunnerBase::CurrentTask();
         future->SetRunning(current);
         future->Task = current;
- 
+
         THolder<THttpCallback> callback(new THttpCallback(future));
         NNeh::TServiceStatRef stat;
         try {
@@ -93,7 +93,7 @@ namespace NRainCheck {
         TTaskRunnerBase* current = TTaskRunnerBase::CurrentTask();
         future->SetRunning(current);
         future->Task = current;
- 
+
         THolder<THttpCallback> callback(new THttpCallback(future));
         NNeh::TServiceStatRef stat;
         try {
@@ -107,11 +107,11 @@ namespace NRainCheck {
             future->SetFail(THttpFuture::OtherError, err.AsStrBuf());
         }
     }
- 
+
     bool THttpFuture::HasHttpCode() const {
         return !!HttpCode;
-    } 
- 
+    }
+
     bool THttpFuture::HasResponseBody() const {
         return !!Response;
     }
@@ -121,7 +121,7 @@ namespace NRainCheck {
         Y_ASSERT(HasHttpCode());
 
         return static_cast<ui32>(*HttpCode);
-    } 
+    }
 
     TString THttpFuture::GetResponseBody() const {
         Y_ASSERT(IsDone());
@@ -149,6 +149,6 @@ namespace NRainCheck {
         ErrorDescription = errorDescription;
         Response.Destroy();
         SetDone();
-    } 
+    }
 
-} 
+}
diff --git a/library/cpp/messagebus/rain_check/http/client.h b/library/cpp/messagebus/rain_check/http/client.h
index 1d1e5005096..d4199c4c98d 100644
--- a/library/cpp/messagebus/rain_check/http/client.h
+++ b/library/cpp/messagebus/rain_check/http/client.h
@@ -10,8 +10,8 @@
 #include <util/system/defaults.h>
 #include <util/system/yassert.h>
 
-class THttpHeaders; 
- 
+class THttpHeaders;
+
 namespace NNeh {
     class IProtocol;
     struct TResponse;
@@ -28,14 +28,14 @@ namespace NRainCheck {
 
             CantResolveNameError = 1,
             BadHttpCodeError = 2,
- 
+
             OtherError = 100
         };
- 
+
     private:
         friend class THttpCallback;
         friend class THttpClientService;
- 
+
     public:
         THttpFuture();
         ~THttpFuture() override;
@@ -53,7 +53,7 @@ namespace NRainCheck {
     private:
         void SetDoneAndSchedule(TAutoPtr<NNeh::TResponse> response);
         void SetFail(EError errorCode, const TStringBuf& errorDescription);
- 
+
     private:
         TTaskRunnerBase* Task;
         TMaybe<HttpCodes> HttpCode;
diff --git a/library/cpp/messagebus/rain_check/http/client_ut.cpp b/library/cpp/messagebus/rain_check/http/client_ut.cpp
index 97a726af448..16281143911 100644
--- a/library/cpp/messagebus/rain_check/http/client_ut.cpp
+++ b/library/cpp/messagebus/rain_check/http/client_ut.cpp
@@ -43,7 +43,7 @@ namespace {
     TString BuildServiceLocation(ui32 port) {
         return Sprintf("http://*:%" PRIu32 "/%s", port, TEST_SERVICE.data());
     }
- 
+
     TString BuildPostServiceLocation(ui32 port) {
         return Sprintf("post://*:%" PRIu32 "/%s", port + 1, TEST_SERVICE.data());
     }
@@ -64,7 +64,7 @@ namespace {
             req->SendReply(response);
         }
     };
- 
+
     NNeh::IServicesRef RunServer(ui32 port, TSimpleServer& server) {
         NNeh::IServicesRef runner = NNeh::CreateLoop();
         runner->Add(BuildServiceLocation(port), server);
@@ -75,7 +75,7 @@ namespace {
             runner->ForkLoop(THR_POOL_SIZE);
         } catch (...) {
             Y_FAIL("Can't run server: %s", CurrentExceptionMessage().data());
-        } 
+        }
 
         return runner;
     }
@@ -94,7 +94,7 @@ namespace {
             , ReqType(param.second)
         {
         }
- 
+
         TContinueFunc Start() override {
             switch (ReqType) {
                 case RT_HTTP_GET: {
@@ -104,7 +104,7 @@ namespace {
                         Env->HttpClientService.Send(getRequest, Requests[i].Get());
                     }
                     break;
-                } 
+                }
                 case RT_HTTP_POST: {
                     TString servicePath = BuildPostServiceLocation(ServerPort);
                     TStringInput headersText(TEST_POST_HEADERS);
@@ -114,8 +114,8 @@ namespace {
                         Env->HttpClientService.SendPost(servicePath, TEST_POST_PARAMS, headers, Requests[i].Get());
                     }
                     break;
-                } 
-            } 
+                }
+            }
 
             return &THttpClientTask::GotReplies;
         }
@@ -154,25 +154,25 @@ Y_UNIT_TEST_SUITE(RainCheckHttpClient) {
         NNeh::IServicesRef runner = RunServer(SERVER_PORT, server);
 
         THttpClientEnv env;
-        TIntrusivePtr<TSimpleTaskRunner> task = env.SpawnTask<THttpClientTask>(TTaskParam(SERVER_PORT, RT_HTTP_GET)); 
+        TIntrusivePtr<TSimpleTaskRunner> task = env.SpawnTask<THttpClientTask>(TTaskParam(SERVER_PORT, RT_HTTP_GET));
 
         env.TestSync.WaitForAndIncrement(1);
     }
- 
+
     Y_UNIT_TEST(SimplePost) {
-        // TODO: randomize port 
-        if (!IsFixedPortTestAllowed()) { 
-            return; 
-        } 
- 
-        TSimpleServer server; 
-        NNeh::IServicesRef runner = RunServer(SERVER_PORT, server); 
- 
-        THttpClientEnv env; 
-        TIntrusivePtr<TSimpleTaskRunner> task = env.SpawnTask<THttpClientTask>(TTaskParam(SERVER_PORT, RT_HTTP_POST)); 
- 
-        env.TestSync.WaitForAndIncrement(1); 
-    } 
+        // TODO: randomize port
+        if (!IsFixedPortTestAllowed()) {
+            return;
+        }
+
+        TSimpleServer server;
+        NNeh::IServicesRef runner = RunServer(SERVER_PORT, server);
+
+        THttpClientEnv env;
+        TIntrusivePtr<TSimpleTaskRunner> task = env.SpawnTask<THttpClientTask>(TTaskParam(SERVER_PORT, RT_HTTP_POST));
+
+        env.TestSync.WaitForAndIncrement(1);
+    }
 
     Y_UNIT_TEST(HttpCodeExtraction) {
     // Find "request failed(" string, then copy len("HTTP/1.X NNN") chars and try to convert NNN to HTTP code.