Restoring authorship annotation for Alexander Fokin <apfokin@gmail.com>. Commit 1 of 2.

4 files changed, 7 insertions, 7 deletions

diff --git a/library/cpp/messagebus/actor/executor.cpp b/library/cpp/messagebus/actor/executor.cpp
index 7a2227a4589..f7244d5f196 100644
--- a/library/cpp/messagebus/actor/executor.cpp
+++ b/library/cpp/messagebus/actor/executor.cpp
@@ -210,7 +210,7 @@ void TExecutor::Stop() {
     ProcessWorkQueueHere();
 }
 
-void TExecutor::EnqueueWork(TArrayRef<IWorkItem* const> wis) {
+void TExecutor::EnqueueWork(TArrayRef<IWorkItem* const> wis) { 
     if (wis.empty())
         return;
 
diff --git a/library/cpp/messagebus/actor/executor.h b/library/cpp/messagebus/actor/executor.h
index 7292d8be53d..e073b6dac67 100644
--- a/library/cpp/messagebus/actor/executor.h
+++ b/library/cpp/messagebus/actor/executor.h
@@ -2,7 +2,7 @@
 
 #include "ring_buffer_with_spin_lock.h"
 
-#include <util/generic/array_ref.h>
+#include <util/generic/array_ref.h> 
 #include <util/generic/vector.h>
 #include <util/system/condvar.h>
 #include <util/system/event.h>
diff --git a/library/cpp/messagebus/actor/ring_buffer.h b/library/cpp/messagebus/actor/ring_buffer.h
index ec5706f7c76..4aaf92bcbcf 100644
--- a/library/cpp/messagebus/actor/ring_buffer.h
+++ b/library/cpp/messagebus/actor/ring_buffer.h
@@ -80,7 +80,7 @@ public:
         return WritePos == ReadPos;
     }
 
-    void PushAll(TArrayRef<const T> value) {
+    void PushAll(TArrayRef<const T> value) { 
         ReserveWritable(value.size());
 
         ui32 secondSize;
@@ -107,7 +107,7 @@ public:
     }
 
     void Push(const T& t) {
-        PushAll(MakeArrayRef(&t, 1));
+        PushAll(MakeArrayRef(&t, 1)); 
     }
 
     bool TryPop(T* r) {
diff --git a/library/cpp/messagebus/actor/ring_buffer_with_spin_lock.h b/library/cpp/messagebus/actor/ring_buffer_with_spin_lock.h
index f0b7cd90e40..4ec1fc2aa4d 100644
--- a/library/cpp/messagebus/actor/ring_buffer_with_spin_lock.h
+++ b/library/cpp/messagebus/actor/ring_buffer_with_spin_lock.h
@@ -21,7 +21,7 @@ public:
         PushAll(t);
     }
 
-    void PushAll(TArrayRef<const T> collection) {
+    void PushAll(TArrayRef<const T> collection) { 
         if (collection.empty()) {
             return;
         }
@@ -59,7 +59,7 @@ public:
         }
     }
 
-    bool PushAllAndTryPop(TArrayRef<const T> collection, T* r) {
+    bool PushAllAndTryPop(TArrayRef<const T> collection, T* r) { 
         if (collection.size() == 0) {
             return TryPop(r);
         } else {
@@ -67,7 +67,7 @@ public:
                 *r = collection[0];
                 if (collection.size() > 1) {
                     TGuard<TSpinLock> guard(SpinLock);
-                    RingBuffer.PushAll(MakeArrayRef(collection.data() + 1, collection.size() - 1));
+                    RingBuffer.PushAll(MakeArrayRef(collection.data() + 1, collection.size() - 1)); 
                     AtomicSet(CachedSize, RingBuffer.Size());
                 }
             } else {