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

2 files changed, 4 insertions, 4 deletions

diff --git a/library/cpp/threading/equeue/equeue.cpp b/library/cpp/threading/equeue/equeue.cpp
index 54a848e912..9d3b2785db 100644
--- a/library/cpp/threading/equeue/equeue.cpp
+++ b/library/cpp/threading/equeue/equeue.cpp
@@ -29,7 +29,7 @@ public:
         AtomicIncrement(Queue_->ObjectCount_);
     }
 
-    ~TDecrementingWrapper() override {
+    ~TDecrementingWrapper() override { 
         AtomicDecrement(Queue_->ObjectCount_);
         AtomicDecrement(Queue_->GuardCount_);
     }
diff --git a/library/cpp/threading/equeue/equeue_ut.cpp b/library/cpp/threading/equeue/equeue_ut.cpp
index 9cf2aced44..5ff4c69347 100644
--- a/library/cpp/threading/equeue/equeue_ut.cpp
+++ b/library/cpp/threading/equeue/equeue_ut.cpp
@@ -41,7 +41,7 @@ Y_UNIT_TEST_SUITE(TElasticQueueTest) {
         Counters.Reset();
 
         struct TWaitJob: public IObjectInQueue {
-            void Process(void*) override {
+            void Process(void*) override { 
                 WaitEvent.Wait();
                 AtomicIncrement(Counters.Processed);
             }
@@ -72,7 +72,7 @@ Y_UNIT_TEST_SUITE(TElasticQueueTest) {
 
 //concurrent test -- send many jobs from different threads
     struct TJob: public IObjectInQueue {
-        void Process(void*) override {
+        void Process(void*) override { 
             AtomicIncrement(Counters.Processed);
         };
     };
@@ -96,7 +96,7 @@ Y_UNIT_TEST_SUITE(TElasticQueueTest) {
         TryCounter = 0;
 
         struct TSender: public IThreadFactory::IThreadAble {
-            void DoExecute() override {
+            void DoExecute() override { 
                 while ((size_t)AtomicIncrement(TryCounter) <= N) {
                     if (!TryAdd()) {
                         Sleep(TDuration::MicroSeconds(50));