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

3 files changed, 8 insertions, 8 deletions

diff --git a/library/cpp/threading/equeue/equeue.cpp b/library/cpp/threading/equeue/equeue.cpp
index 4a708ef3ad9..54a848e912a 100644
--- a/library/cpp/threading/equeue/equeue.cpp
+++ b/library/cpp/threading/equeue/equeue.cpp
@@ -71,10 +71,10 @@ void TElasticQueue::Start(size_t threadCount, size_t maxQueueSize) {
     SlaveQueue_->Start(threadCount, maxQueueSize);
 }
 
-void TElasticQueue::Stop() noexcept { 
+void TElasticQueue::Stop() noexcept {
     return SlaveQueue_->Stop();
 }
 
-size_t TElasticQueue::Size() const noexcept { 
+size_t TElasticQueue::Size() const noexcept {
     return SlaveQueue_->Size();
 }
diff --git a/library/cpp/threading/equeue/equeue.h b/library/cpp/threading/equeue/equeue.h
index ff735399e68..40dd342585e 100644
--- a/library/cpp/threading/equeue/equeue.h
+++ b/library/cpp/threading/equeue/equeue.h
@@ -1,11 +1,11 @@
 #pragma once
 
-#include <util/thread/pool.h> 
+#include <util/thread/pool.h>
 #include <util/system/atomic.h>
 #include <util/generic/ptr.h>
 
 //actual queue limit will be (maxQueueSize - numBusyThreads) or 0
-class TElasticQueue: public IThreadPool { 
+class TElasticQueue: public IThreadPool {
 public:
     explicit TElasticQueue(THolder<IThreadPool> slaveQueue);
 
@@ -21,7 +21,7 @@ private:
 
     bool TryIncCounter();
 private:
-    THolder<IThreadPool> SlaveQueue_; 
+    THolder<IThreadPool> SlaveQueue_;
     size_t MaxQueueSize_ = 0;
     TAtomic ObjectCount_ = 0;
     TAtomic GuardCount_ = 0;
diff --git a/library/cpp/threading/equeue/equeue_ut.cpp b/library/cpp/threading/equeue/equeue_ut.cpp
index d08a94848b3..9cf2aced44e 100644
--- a/library/cpp/threading/equeue/equeue_ut.cpp
+++ b/library/cpp/threading/equeue/equeue_ut.cpp
@@ -95,7 +95,7 @@ Y_UNIT_TEST_SUITE(TElasticQueueTest) {
         Counters.Reset();
         TryCounter = 0;
 
-        struct TSender: public IThreadFactory::IThreadAble { 
+        struct TSender: public IThreadFactory::IThreadAble {
             void DoExecute() override {
                 while ((size_t)AtomicIncrement(TryCounter) <= N) {
                     if (!TryAdd()) {
@@ -108,9 +108,9 @@ Y_UNIT_TEST_SUITE(TElasticQueueTest) {
         {
             TQueueSetup setup;
 
-            TVector< TAutoPtr<IThreadFactory::IThread> > senders; 
+            TVector< TAutoPtr<IThreadFactory::IThread> > senders;
             for (size_t i = 0; i < ThreadCount; ++i) {
-                senders.push_back(::SystemThreadFactory()->Run(&sender)); 
+                senders.push_back(::SystemThreadFactory()->Run(&sender));
             }
 
             for (size_t i = 0; i < senders.size(); ++i) {