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

1 files changed, 9 insertions, 9 deletions

diff --git a/library/cpp/messagebus/event_loop.cpp b/library/cpp/messagebus/event_loop.cpp
index fd2e726d0b..f685135bed 100644
--- a/library/cpp/messagebus/event_loop.cpp
+++ b/library/cpp/messagebus/event_loop.cpp
@@ -78,7 +78,7 @@ public:
 
     const char* Name;
 
-    TAtomic RunningState; 
+    TAtomic RunningState;
     TAtomic StopSignal;
     TSystemEvent StoppedEvent;
     TData Data;
@@ -143,7 +143,7 @@ void TEventLoop::Stop() {
 }
 
 bool TEventLoop::IsRunning() {
-    return AtomicGet(Impl->RunningState) == EVENT_LOOP_RUNNING; 
+    return AtomicGet(Impl->RunningState) == EVENT_LOOP_RUNNING;
 }
 
 TChannelPtr TEventLoop::Register(TSocket socket, TEventHandlerPtr eventHandler, void* cookie) {
@@ -277,7 +277,7 @@ TEventLoop::TImpl::TImpl(const char* name)
 }
 
 void TEventLoop::TImpl::Run() {
-    bool res = AtomicCas(&RunningState, EVENT_LOOP_RUNNING, EVENT_LOOP_CREATED); 
+    bool res = AtomicCas(&RunningState, EVENT_LOOP_RUNNING, EVENT_LOOP_CREATED);
     Y_VERIFY(res, "Invalid mbus event loop state");
 
     if (!!Name) {
@@ -320,21 +320,21 @@ void TEventLoop::TImpl::Run() {
         Data.clear();
     }
 
-    res = AtomicCas(&RunningState, EVENT_LOOP_STOPPED, EVENT_LOOP_RUNNING); 
+    res = AtomicCas(&RunningState, EVENT_LOOP_STOPPED, EVENT_LOOP_RUNNING);
 
     Y_VERIFY(res);
- 
+
     StoppedEvent.Signal();
 }
 
 void TEventLoop::TImpl::Stop() {
     AtomicSet(StopSignal, 1);
 
-    if (AtomicGet(RunningState) == EVENT_LOOP_RUNNING) { 
-        Wakeup(); 
+    if (AtomicGet(RunningState) == EVENT_LOOP_RUNNING) {
+        Wakeup();
 
-        StoppedEvent.WaitI(); 
-    } 
+        StoppedEvent.WaitI();
+    }
 }
 
 TChannelPtr TEventLoop::TImpl::Register(TSocket socket, TEventHandlerPtr eventHandler, void* cookie) {