Restoring authorship annotation for Vlad Yaroslavlev <vladon@vladon.com>. Commit 2 of 2.

5 files changed, 15 insertions, 15 deletions

diff --git a/library/cpp/messagebus/test/helper/example.cpp b/library/cpp/messagebus/test/helper/example.cpp
index f5b21be799..7c6d704042 100644
--- a/library/cpp/messagebus/test/helper/example.cpp
+++ b/library/cpp/messagebus/test/helper/example.cpp
@@ -19,12 +19,12 @@ static void FillWithJunk(TArrayRef<char> data) {
     }
 }
 
-static TString JunkString(size_t len) { 
+static TString JunkString(size_t len) {
     TTempBuf temp(len);
     TArrayRef<char> tempArrayRef(temp.Data(), len);
     FillWithJunk(tempArrayRef);
 
-    return TString(tempArrayRef.data(), tempArrayRef.size()); 
+    return TString(tempArrayRef.data(), tempArrayRef.size());
 }
 
 TExampleRequest::TExampleRequest(TAtomic* counterPtr, size_t payloadSize)
diff --git a/library/cpp/messagebus/test/helper/hanging_server.h b/library/cpp/messagebus/test/helper/hanging_server.h
index f6b9af24e2..cc9fb274d8 100644
--- a/library/cpp/messagebus/test/helper/hanging_server.h
+++ b/library/cpp/messagebus/test/helper/hanging_server.h
@@ -6,7 +6,7 @@
 
 class THangingServer {
 private:
-    std::pair<unsigned, TVector<NBus::TBindResult>> BindResult; 
+    std::pair<unsigned, TVector<NBus::TBindResult>> BindResult;
 
 public:
     // listen on given port, and nothing else
diff --git a/library/cpp/messagebus/test/perftest/perftest.cpp b/library/cpp/messagebus/test/perftest/perftest.cpp
index dd2dd69e4d..8489319278 100644
--- a/library/cpp/messagebus/test/perftest/perftest.cpp
+++ b/library/cpp/messagebus/test/perftest/perftest.cpp
@@ -17,7 +17,7 @@
 #include <library/cpp/threading/future/legacy_future.h>
 
 #include <util/generic/ptr.h>
-#include <util/generic/string.h> 
+#include <util/generic/string.h>
 #include <util/generic/vector.h>
 #include <util/generic/yexception.h>
 #include <util/random/random.h>
@@ -76,7 +76,7 @@ struct TPerftestConfig {
 extern TPerftestConfig* TheConfig;
 extern bool TheExit;
 
-TVector<TNetAddr> ServerAddresses; 
+TVector<TNetAddr> ServerAddresses;
 
 struct TConfig {
     TBusQueueConfig ServerQueueConfig;
@@ -142,13 +142,13 @@ TAutoPtr<TBusMessage> NewRequest() {
         TAutoPtr<TPerftestRequest> r(new TPerftestRequest);
         r->SetCompressed(TheConfig->UseCompression);
         // TODO: use random content for better compression test
-        r->Record.SetData(TString(RequestSize(), '?')); 
+        r->Record.SetData(TString(RequestSize(), '?'));
         return r.Release();
     }
 }
 
 void CheckRequest(TPerftestRequest* request) {
-    const TString& data = request->Record.GetData(); 
+    const TString& data = request->Record.GetData();
     for (size_t i = 0; i != data.size(); ++i) {
         Y_VERIFY(data.at(i) == '?', "must be question mark");
     }
@@ -162,7 +162,7 @@ TAutoPtr<TPerftestResponse> NewResponse(TPerftestRequest* request) {
 }
 
 void CheckResponse(TPerftestResponse* response) {
-    const TString& data = response->Record.GetData(); 
+    const TString& data = response->Record.GetData();
     for (size_t i = 0; i != data.size(); ++i) {
         Y_VERIFY(data.at(i) == '.', "must be dot");
     }
@@ -237,7 +237,7 @@ public:
     TBusClientSessionPtr Session;
     THolder<TBusProtocol> Proto;
     TBusMessageQueuePtr Bus;
-    TVector<TBusClientConnectionPtr> Connections; 
+    TVector<TBusClientConnectionPtr> Connections;
 
 public:
     /// constructor creates instances of protocol and session
@@ -470,10 +470,10 @@ static TNetworkAddress ParseNetworkAddress(const char* string) {
     return TNetworkAddress(Name, Port);
 }
 
-TVector<TNetAddr> ParseNodes(const TString nodes) { 
-    TVector<TNetAddr> r; 
+TVector<TNetAddr> ParseNodes(const TString nodes) {
+    TVector<TNetAddr> r;
 
-    TVector<TString> hosts; 
+    TVector<TString> hosts;
 
     size_t numh = Split(nodes.data(), ",", hosts);
 
@@ -583,7 +583,7 @@ void TTestStats::PeriodicallyPrint() {
             stats << IndentText(client->Bus->GetStatus());
         }
 
-        TUnbufferedFileOutput("stats").Write(stats.Str()); 
+        TUnbufferedFileOutput("stats").Write(stats.Str());
     }
 }
 
diff --git a/library/cpp/messagebus/test/ut/locator_uniq_ut.cpp b/library/cpp/messagebus/test/ut/locator_uniq_ut.cpp
index a930e26dcd..3fdd175d73 100644
--- a/library/cpp/messagebus/test/ut/locator_uniq_ut.cpp
+++ b/library/cpp/messagebus/test/ut/locator_uniq_ut.cpp
@@ -31,7 +31,7 @@ void TLocatorRegisterUniqTest::TestRegister() {
     /// YBUS_KEYMIN YBUS_KEYMAX range
     UNIT_ASSERT(keys.size() == 1);
 
-    TVector<NBus::TNetAddr> hosts; 
+    TVector<NBus::TNetAddr> hosts;
     UNIT_ASSERT(locator.LocateAll(serviceName, NBus::YBUS_KEYMIN, hosts) == 1);
 
     locator.Register(serviceName, hostName, port);
diff --git a/library/cpp/messagebus/test/ut/messagebus_ut.cpp b/library/cpp/messagebus/test/ut/messagebus_ut.cpp
index 5bae0e7bb9..040f9b7702 100644
--- a/library/cpp/messagebus/test/ut/messagebus_ut.cpp
+++ b/library/cpp/messagebus/test/ut/messagebus_ut.cpp
@@ -311,7 +311,7 @@ Y_UNIT_TEST_SUITE(TMessageBusTests) {
         TSystemEvent MessageReceivedEvent; // 1 wait for 1 message
         TBusServerSessionPtr Session;
         TMutex Lock_;
-        TDeque<TAutoPtr<TOnMessageContext>> DelayedMessages; 
+        TDeque<TAutoPtr<TOnMessageContext>> DelayedMessages;
 
         TDelayReplyServer()
             : MessageReceivedEvent(TEventResetType::rAuto)