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

4 files changed, 10 insertions, 10 deletions

diff --git a/library/cpp/messagebus/async_result.h b/library/cpp/messagebus/async_result.h
index d24dde284a..1aaa6b26ff 100644
--- a/library/cpp/messagebus/async_result.h
+++ b/library/cpp/messagebus/async_result.h
@@ -5,8 +5,8 @@
 #include <util/system/condvar.h>
 #include <util/system/mutex.h>
 #include <util/system/yassert.h>
-
-#include <functional>
+ 
+#include <functional> 
 
 // probably this thing should have been called TFuture
 template <typename T>
@@ -19,7 +19,7 @@ private:
 
     typedef void TOnResult(const T&);
 
-    std::function<TOnResult> OnResult;
+    std::function<TOnResult> OnResult; 
 
 public:
     void SetResult(const T& result) {
@@ -48,7 +48,7 @@ public:
             onResult(*Result);
         } else {
             Y_ASSERT(!OnResult);
-            OnResult = std::function<TOnResult>(onResult);
+            OnResult = std::function<TOnResult>(onResult); 
         }
     }
 };
diff --git a/library/cpp/messagebus/async_result_ut.cpp b/library/cpp/messagebus/async_result_ut.cpp
index 2e96492afd..8ef034ef1d 100644
--- a/library/cpp/messagebus/async_result_ut.cpp
+++ b/library/cpp/messagebus/async_result_ut.cpp
@@ -18,7 +18,7 @@ Y_UNIT_TEST_SUITE(TAsyncResult) {
 
         r.SetResult(17);
 
-        r.AndThen(std::bind(&SetValue, &var, std::placeholders::_1));
+        r.AndThen(std::bind(&SetValue, &var, std::placeholders::_1)); 
 
         UNIT_ASSERT_VALUES_EQUAL(17, var);
     }
@@ -28,7 +28,7 @@ Y_UNIT_TEST_SUITE(TAsyncResult) {
 
         int var = 1;
 
-        r.AndThen(std::bind(&SetValue, &var, std::placeholders::_1));
+        r.AndThen(std::bind(&SetValue, &var, std::placeholders::_1)); 
 
         r.SetResult(17);
 
diff --git a/library/cpp/messagebus/session_impl.cpp b/library/cpp/messagebus/session_impl.cpp
index ddf9f360c4..7b2e4f519e 100644
--- a/library/cpp/messagebus/session_impl.cpp
+++ b/library/cpp/messagebus/session_impl.cpp
@@ -110,7 +110,7 @@ TBusSessionImpl::TBusSessionImpl(bool isSource, TBusMessageQueue* queue, TBusPro
 {
     Impl->DeadAcceptorStatusSummary.Summary = true;
 
-    ReadEventLoopThread.Reset(new NThreading::TLegacyFuture<void, false>(std::bind(&TEventLoop::Run, std::ref(ReadEventLoop))));
+    ReadEventLoopThread.Reset(new NThreading::TLegacyFuture<void, false>(std::bind(&TEventLoop::Run, std::ref(ReadEventLoop)))); 
     WriteEventLoopThread.Reset(new NThreading::TLegacyFuture<void, false>(std::bind(&TEventLoop::Run, std::ref(WriteEventLoop))));
 
     Queue->Schedule(IScheduleItemAutoPtr(new TScheduleSession(this, TInstant::Now() + Config.Secret.TimeoutPeriod)));
@@ -442,7 +442,7 @@ void TBusSessionImpl::Act(TStatusTag) {
 
     EShutdownState shutdownState = StatusData.ShutdownState.State.Get();
 
-    StatusData.ConnectionsAcceptorsSnapshotsQueue.DequeueAllLikelyEmpty(std::bind(&TBusSessionImpl::ProcessConnectionsAcceptorsShapshotQueueItem, this, std::placeholders::_1));
+    StatusData.ConnectionsAcceptorsSnapshotsQueue.DequeueAllLikelyEmpty(std::bind(&TBusSessionImpl::ProcessConnectionsAcceptorsShapshotQueueItem, this, std::placeholders::_1)); 
 
     GetDeadConnectionWriterStatusQueue()->DequeueAllLikelyEmpty();
     GetDeadConnectionReaderStatusQueue()->DequeueAllLikelyEmpty();
diff --git a/library/cpp/messagebus/test/perftest/perftest.cpp b/library/cpp/messagebus/test/perftest/perftest.cpp
index 8489319278..2b3b9d2f05 100644
--- a/library/cpp/messagebus/test/perftest/perftest.cpp
+++ b/library/cpp/messagebus/test/perftest/perftest.cpp
@@ -658,12 +658,12 @@ int main(int argc, char* argv[]) {
         for (int i = 0; i < TheConfig->ClientCount; ++i) {
             TGuard<TMutex> guard(ClientsLock);
             Clients.push_back(new TPerftestClient);
-            futures.push_back(new NThreading::TLegacyFuture<void, false>(std::bind(&TPerftestClient::Work, Clients.back())));
+            futures.push_back(new NThreading::TLegacyFuture<void, false>(std::bind(&TPerftestClient::Work, Clients.back()))); 
             www->RegisterClientSession(Clients.back()->Session);
         }
     }
 
-    futures.push_back(new NThreading::TLegacyFuture<void, false>(std::bind(&TTestStats::PeriodicallyPrint, std::ref(Stats))));
+    futures.push_back(new NThreading::TLegacyFuture<void, false>(std::bind(&TTestStats::PeriodicallyPrint, std::ref(Stats)))); 
 
     THolder<TBusWwwHttpServer> wwwServer;
     if (TheConfig->WwwPort != 0) {