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

1 files changed, 87 insertions, 87 deletions

diff --git a/util/system/rwlock_ut.cpp b/util/system/rwlock_ut.cpp
index 2b384c05b3d..8763f46cbd8 100644
--- a/util/system/rwlock_ut.cpp
+++ b/util/system/rwlock_ut.cpp
@@ -1,15 +1,15 @@
-#include "rwlock.h"
-#include "atomic.h"
-
+#include "rwlock.h" 
+#include "atomic.h" 
+ 
 #include <library/cpp/testing/unittest/registar.h>
 
 #include <util/thread/pool.h>
 #include <util/random/random.h>
 
-class TRWMutexTest: public TTestBase {
+class TRWMutexTest: public TTestBase { 
     UNIT_TEST_SUITE(TRWMutexTest);
-    UNIT_TEST(TestReaders)
-    UNIT_TEST(TestReadersWriters)
+    UNIT_TEST(TestReaders) 
+    UNIT_TEST(TestReadersWriters) 
     UNIT_TEST_SUITE_END();
 
     struct TSharedData {
@@ -20,104 +20,104 @@ class TRWMutexTest: public TTestBase {
         {
         }
 
-        TAtomic writersIn;
-        TAtomic readersIn;
+        TAtomic writersIn; 
+        TAtomic readersIn; 
 
         bool failed;
 
         TRWMutex mutex;
     };
-
-    class TThreadTask: public IObjectInQueue {
-    public:
+ 
+    class TThreadTask: public IObjectInQueue { 
+    public: 
         using PFunc = void (TThreadTask::*)(void);
 
-        TThreadTask(PFunc func, TSharedData& data, size_t id, size_t total)
-            : Func_(func)
-            , Data_(data)
-            , Id_(id)
-            , Total_(total)
-        {
-        }
+        TThreadTask(PFunc func, TSharedData& data, size_t id, size_t total) 
+            : Func_(func) 
+            , Data_(data) 
+            , Id_(id) 
+            , Total_(total) 
+        { 
+        } 
 
         void Process(void*) override {
-            THolder<TThreadTask> This(this);
-
-            (this->*Func_)();
-        }
-
-#define FAIL_ASSERT(cond)    \
-    if (!(cond)) {           \
-        Data_.failed = true; \
+            THolder<TThreadTask> This(this); 
+ 
+            (this->*Func_)(); 
+        } 
+
+#define FAIL_ASSERT(cond)    \ 
+    if (!(cond)) {           \ 
+        Data_.failed = true; \ 
     }
-        void RunReaders() {
-            Data_.mutex.AcquireRead();
-
-            AtomicIncrement(Data_.readersIn);
-            usleep(100);
-            FAIL_ASSERT(Data_.readersIn == long(Total_));
-            usleep(100);
-            AtomicDecrement(Data_.readersIn);
-
-            Data_.mutex.ReleaseRead();
-        }
-
-        void RunReadersWriters() {
-            if (Id_ % 2 == 0) {
-                for (size_t i = 0; i < 10; ++i) {
-                    Data_.mutex.AcquireRead();
-
-                    AtomicIncrement(Data_.readersIn);
-                    FAIL_ASSERT(Data_.writersIn == 0);
-                    usleep(RandomNumber<ui32>() % 5);
-                    AtomicDecrement(Data_.readersIn);
-
-                    Data_.mutex.ReleaseRead();
-                }
-            } else {
-                for (size_t i = 0; i < 10; ++i) {
-                    Data_.mutex.AcquireWrite();
-
-                    AtomicIncrement(Data_.writersIn);
-                    FAIL_ASSERT(Data_.readersIn == 0 && Data_.writersIn == 1);
-                    usleep(RandomNumber<ui32>() % 5);
-                    AtomicDecrement(Data_.writersIn);
-
-                    Data_.mutex.ReleaseWrite();
+        void RunReaders() { 
+            Data_.mutex.AcquireRead(); 
+
+            AtomicIncrement(Data_.readersIn); 
+            usleep(100); 
+            FAIL_ASSERT(Data_.readersIn == long(Total_)); 
+            usleep(100); 
+            AtomicDecrement(Data_.readersIn); 
+
+            Data_.mutex.ReleaseRead(); 
+        } 
+
+        void RunReadersWriters() { 
+            if (Id_ % 2 == 0) { 
+                for (size_t i = 0; i < 10; ++i) { 
+                    Data_.mutex.AcquireRead(); 
+
+                    AtomicIncrement(Data_.readersIn); 
+                    FAIL_ASSERT(Data_.writersIn == 0); 
+                    usleep(RandomNumber<ui32>() % 5); 
+                    AtomicDecrement(Data_.readersIn); 
+
+                    Data_.mutex.ReleaseRead(); 
+                } 
+            } else { 
+                for (size_t i = 0; i < 10; ++i) { 
+                    Data_.mutex.AcquireWrite(); 
+
+                    AtomicIncrement(Data_.writersIn); 
+                    FAIL_ASSERT(Data_.readersIn == 0 && Data_.writersIn == 1); 
+                    usleep(RandomNumber<ui32>() % 5); 
+                    AtomicDecrement(Data_.writersIn); 
+
+                    Data_.mutex.ReleaseWrite(); 
                 }
             }
-        }
+        } 
 #undef FAIL_ASSERT
 
-    private:
-        PFunc Func_;
-        TSharedData& Data_;
-        size_t Id_;
-        size_t Total_;
+    private: 
+        PFunc Func_; 
+        TSharedData& Data_; 
+        size_t Id_; 
+        size_t Total_; 
     };
-
-private:
-#define RUN_CYCLE(what, count)                                                     \
-    Q_.Start(count);                                                               \
-    for (size_t i = 0; i < count; ++i) {                                           \
-        UNIT_ASSERT(Q_.Add(new TThreadTask(&TThreadTask::what, Data_, i, count))); \
-    }                                                                              \
-    Q_.Stop();                                                                     \
-    bool b = Data_.failed;                                                         \
-    Data_.failed = false;                                                          \
-    UNIT_ASSERT(!b);
-
-    void TestReaders() {
-        RUN_CYCLE(RunReaders, 1);
-    }
-
-    void TestReadersWriters() {
-        RUN_CYCLE(RunReadersWriters, 1);
-    }
+ 
+private: 
+#define RUN_CYCLE(what, count)                                                     \ 
+    Q_.Start(count);                                                               \ 
+    for (size_t i = 0; i < count; ++i) {                                           \ 
+        UNIT_ASSERT(Q_.Add(new TThreadTask(&TThreadTask::what, Data_, i, count))); \ 
+    }                                                                              \ 
+    Q_.Stop();                                                                     \ 
+    bool b = Data_.failed;                                                         \ 
+    Data_.failed = false;                                                          \ 
+    UNIT_ASSERT(!b); 
+
+    void TestReaders() { 
+        RUN_CYCLE(RunReaders, 1); 
+    } 
+
+    void TestReadersWriters() { 
+        RUN_CYCLE(RunReadersWriters, 1); 
+    } 
 
 #undef RUN_CYCLE
-private:
-    TSharedData Data_;
+private: 
+    TSharedData Data_; 
     TThreadPool Q_;
 };