From 55a7f90e4cd31e9481cace8ee5dfd682c27e810e Mon Sep 17 00:00:00 2001
From: tobo <tobo@yandex-team.ru>
Date: Thu, 10 Feb 2022 16:47:27 +0300
Subject: Restoring authorship annotation for <tobo@yandex-team.ru>. Commit 2
 of 2.

---
 library/cpp/threading/equeue/equeue.cpp    | 2 +-
 library/cpp/threading/equeue/equeue_ut.cpp | 6 +++---
 2 files changed, 4 insertions(+), 4 deletions(-)

(limited to 'library/cpp/threading/equeue')

diff --git a/library/cpp/threading/equeue/equeue.cpp b/library/cpp/threading/equeue/equeue.cpp
index 9d3b2785db0..54a848e912a 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 5ff4c693476..9cf2aced44e 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));
-- 
cgit v1.3