Restoring authorship annotation for <[email protected]>. Commit 1 of 2.

4 files changed, 51 insertions, 51 deletions

diff --git a/library/cpp/messagebus/oldmodule/startsession.h b/library/cpp/messagebus/oldmodule/startsession.h
index 5e26e7e1e56..cb31217dd84 100644
--- a/library/cpp/messagebus/oldmodule/startsession.h
+++ b/library/cpp/messagebus/oldmodule/startsession.h
@@ -27,7 +27,7 @@ namespace NBus {
     public:
         TBusStarter(TBusModule* module, const TBusSessionConfig& config);
         ~TBusStarter();
-
+ 
         void Shutdown();
     };
 
diff --git a/library/cpp/messagebus/synchandler.cpp b/library/cpp/messagebus/synchandler.cpp
index 8e891d66b30..c95ada8039b 100644
--- a/library/cpp/messagebus/synchandler.cpp
+++ b/library/cpp/messagebus/synchandler.cpp
@@ -1,32 +1,32 @@
 #include "remote_client_session.h"
 #include "remote_connection.h"
 #include "ybus.h"
-
+ 
 using namespace NBus;
 using namespace NBus::NPrivate;
 
-/////////////////////////////////////////////////////////////////
-/// Object that encapsulates all messgae data required for sending
-/// a message synchronously and receiving a reply. It includes:
-/// 1. ConditionVariable to wait on message reply
-/// 2. Lock used by condition variable
-/// 3. Message reply
-/// 4. Reply status
-struct TBusSyncMessageData {
+///////////////////////////////////////////////////////////////// 
+/// Object that encapsulates all messgae data required for sending 
+/// a message synchronously and receiving a reply. It includes: 
+/// 1. ConditionVariable to wait on message reply 
+/// 2. Lock used by condition variable 
+/// 3. Message reply 
+/// 4. Reply status 
+struct TBusSyncMessageData { 
     TCondVar ReplyEvent;
     TMutex ReplyLock;
     TBusMessage* Reply;
-    EMessageStatus ReplyStatus;
-
-    TBusSyncMessageData()
+    EMessageStatus ReplyStatus; 
+ 
+    TBusSyncMessageData() 
         : Reply(nullptr)
-        , ReplyStatus(MESSAGE_DONT_ASK)
+        , ReplyStatus(MESSAGE_DONT_ASK) 
     {
     }
-};
-
+}; 
+ 
 class TSyncHandler: public IBusClientHandler {
-public:
+public: 
     TSyncHandler(bool expectReply = true)
         : ExpectReply(expectReply)
         , Session(nullptr)
@@ -34,7 +34,7 @@ public:
     }
     ~TSyncHandler() override {
     }
-
+ 
     void OnReply(TAutoPtr<TBusMessage> pMessage0, TAutoPtr<TBusMessage> pReply0) override {
         TBusMessage* pMessage = pMessage0.Release();
         TBusMessage* pReply = pReply0.Release();
@@ -45,15 +45,15 @@ public:
 
         TBusSyncMessageData* data = static_cast<TBusSyncMessageData*>(pMessage->Data);
         SignalResult(data, pReply, MESSAGE_OK);
-    }
-
+    } 
+ 
     void OnError(TAutoPtr<TBusMessage> pMessage0, EMessageStatus status) override {
         TBusMessage* pMessage = pMessage0.Release();
         TBusSyncMessageData* data = static_cast<TBusSyncMessageData*>(pMessage->Data);
-        if (!data) {
-            return;
-        }
-
+        if (!data) { 
+            return; 
+        } 
+ 
         SignalResult(data, /*pReply=*/nullptr, status);
     }
 
@@ -77,18 +77,18 @@ public:
 private:
     void SignalResult(TBusSyncMessageData* data, TBusMessage* pReply, EMessageStatus status) const {
         Y_VERIFY(data, "Message data is set to NULL.");
-        TGuard<TMutex> G(data->ReplyLock);
+        TGuard<TMutex> G(data->ReplyLock); 
         data->Reply = pReply;
-        data->ReplyStatus = status;
-        data->ReplyEvent.Signal();
-    }
+        data->ReplyStatus = status; 
+        data->ReplyEvent.Signal(); 
+    } 
 
 private:
     // This is weird, because in regular client one-way-ness is selected per call, not per session.
     bool ExpectReply;
     TRemoteClientSession* Session;
-};
-
+}; 
+ 
 namespace NBus {
     namespace NPrivate {
 #ifdef _MSC_VER
@@ -168,31 +168,31 @@ void TBusSyncSourceSession::Shutdown() {
 
 TBusMessage* TBusSyncSourceSession::SendSyncMessage(TBusMessage* pMessage, EMessageStatus& status, const TNetAddr* addr) {
     return Session->SendSyncMessage(pMessage, status, addr);
-}
-
+} 
+ 
 int TBusSyncSourceSession::RegisterService(const char* hostname, TBusKey start, TBusKey end, EIpVersion ipVersion) {
     return Session->RegisterService(hostname, start, end, ipVersion);
 }
-
+ 
 int TBusSyncSourceSession::GetInFlight() {
     return Session->GetInFlight();
 }
-
+ 
 const TBusProtocol* TBusSyncSourceSession::GetProto() const {
     return Session->GetProto();
 }
-
+ 
 const TBusClientSession* TBusSyncSourceSession::GetBusClientSessionWorkaroundDoNotUse() const {
     return Session.Get();
 }
-
+ 
 TBusSyncClientSessionPtr TBusMessageQueue::CreateSyncSource(TBusProtocol* proto, const TBusClientSessionConfig& config, bool needReply, const TString& name) {
     TIntrusivePtr<TBusSyncSourceSessionImpl> session = new TBusSyncSourceSessionImpl(this, proto, config, needReply, name);
     Add(session.Get());
     return new TBusSyncSourceSession(session);
 }
-
+ 
 void TBusMessageQueue::Destroy(TBusSyncClientSessionPtr session) {
     Destroy(session->Session.Get());
     Y_UNUSED(session->Session.Release());
-}
+} 
diff --git a/library/cpp/messagebus/test/ut/sync_client_ut.cpp b/library/cpp/messagebus/test/ut/sync_client_ut.cpp
index 400128193f9..b3d5e746523 100644
--- a/library/cpp/messagebus/test/ut/sync_client_ut.cpp
+++ b/library/cpp/messagebus/test/ut/sync_client_ut.cpp
@@ -1,7 +1,7 @@
 #include <library/cpp/messagebus/test/helper/example.h>
 #include <library/cpp/messagebus/test/helper/object_count_check.h>
-
-namespace NBus {
+ 
+namespace NBus { 
     namespace NTest {
         using namespace std;
 
@@ -9,34 +9,34 @@ namespace NBus {
         /// \brief Client for sending synchronous message to local server
         struct TSyncClient {
             TNetAddr ServerAddr;
-
+ 
             TExampleProtocol Proto;
             TBusMessageQueuePtr Bus;
             TBusSyncClientSessionPtr Session;
 
             int NumReplies;
             int NumMessages;
-
+ 
             /// constructor creates instances of queue, protocol and session
             TSyncClient(const TNetAddr& serverAddr)
                 : ServerAddr(serverAddr)
             {
                 /// create or get instance of message queue, need one per application
                 Bus = CreateMessageQueue();
-
+ 
                 NumReplies = 0;
                 NumMessages = 10;
-
+ 
                 /// register source/client session
                 TBusClientSessionConfig sessionConfig;
                 Session = Bus->CreateSyncSource(&Proto, sessionConfig);
                 Session->RegisterService("localhost");
             }
-
+ 
             ~TSyncClient() {
                 Session->Shutdown();
             }
-
+ 
             /// dispatch of requests is done here
             void Work() {
                 for (int i = 0; i < NumMessages; i++) {
@@ -49,7 +49,7 @@ namespace NBus {
                 }
             }
         };
-
+ 
         Y_UNIT_TEST_SUITE(SyncClientTest) {
             Y_UNIT_TEST(TestSync) {
                 TObjectCountCheck objectCountCheck;
@@ -63,7 +63,7 @@ namespace NBus {
                 UNIT_ASSERT_EQUAL(server.Session->GetInFlight(), 0);
                 UNIT_ASSERT_EQUAL(client.Session->GetInFlight(), 0);
             }
-        }
-
+        } 
+ 
     }
 }
diff --git a/library/cpp/messagebus/ybus.h b/library/cpp/messagebus/ybus.h
index de21ad85216..b3638998556 100644
--- a/library/cpp/messagebus/ybus.h
+++ b/library/cpp/messagebus/ybus.h
@@ -29,10 +29,10 @@
 #include <util/generic/ptr.h>
 #include <util/stream/input.h>
 #include <util/system/atomic.h>
-#include <util/system/condvar.h>
+#include <util/system/condvar.h> 
 #include <util/system/type_name.h>
 #include <util/system/event.h>
-#include <util/system/mutex.h>
+#include <util/system/mutex.h> 
 
 namespace NBus {
     ////////////////////////////////////////////////////////