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

1 files changed, 25 insertions, 25 deletions

diff --git a/library/cpp/threading/equeue/equeue.h b/library/cpp/threading/equeue/equeue.h
index 403e993713..40dd342585 100644
--- a/library/cpp/threading/equeue/equeue.h
+++ b/library/cpp/threading/equeue/equeue.h
@@ -1,28 +1,28 @@
-#pragma once 
- 
+#pragma once
+
 #include <util/thread/pool.h>
-#include <util/system/atomic.h> 
-#include <util/generic/ptr.h> 
- 
-//actual queue limit will be (maxQueueSize - numBusyThreads) or 0 
+#include <util/system/atomic.h>
+#include <util/generic/ptr.h>
+
+//actual queue limit will be (maxQueueSize - numBusyThreads) or 0
 class TElasticQueue: public IThreadPool {
-public: 
-    explicit TElasticQueue(THolder<IThreadPool> slaveQueue); 
- 
-    bool Add(IObjectInQueue* obj) override; 
-    size_t Size() const noexcept override; 
- 
-    void Start(size_t threadCount, size_t maxQueueSize) override; 
-    void Stop() noexcept override; 
- 
-    size_t ObjectCount() const; 
-private: 
-    class TDecrementingWrapper; 
- 
-    bool TryIncCounter(); 
-private: 
+public:
+    explicit TElasticQueue(THolder<IThreadPool> slaveQueue);
+
+    bool Add(IObjectInQueue* obj) override;
+    size_t Size() const noexcept override;
+
+    void Start(size_t threadCount, size_t maxQueueSize) override;
+    void Stop() noexcept override;
+
+    size_t ObjectCount() const;
+private:
+    class TDecrementingWrapper;
+
+    bool TryIncCounter();
+private:
     THolder<IThreadPool> SlaveQueue_;
-    size_t MaxQueueSize_ = 0; 
-    TAtomic ObjectCount_ = 0; 
-    TAtomic GuardCount_ = 0; 
-}; 
+    size_t MaxQueueSize_ = 0;
+    TAtomic ObjectCount_ = 0;
+    TAtomic GuardCount_ = 0;
+};