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

2 files changed, 197 insertions, 197 deletions

diff --git a/library/cpp/threading/light_rw_lock/bench/lightrwlock_test.cpp b/library/cpp/threading/light_rw_lock/bench/lightrwlock_test.cpp
index c3027ea544..5e217c25ad 100644
--- a/library/cpp/threading/light_rw_lock/bench/lightrwlock_test.cpp
+++ b/library/cpp/threading/light_rw_lock/bench/lightrwlock_test.cpp
@@ -1,188 +1,188 @@
 #include <library/cpp/threading/light_rw_lock/lightrwlock.h>
-#include <util/random/random.h>
-
-#ifdef _linux_
-// Light rw lock is implemented only for linux
-
-using namespace NS_LightRWLock;
-
-#include <pthread.h>
-#include <stdlib.h>
-#include <stdio.h>
-
-#define LIGHT
-
-#ifdef RWSPINLOCK
+#include <util/random/random.h> 
+ 
+#ifdef _linux_ 
+// Light rw lock is implemented only for linux 
+ 
+using namespace NS_LightRWLock; 
+ 
+#include <pthread.h> 
+#include <stdlib.h> 
+#include <stdio.h> 
+ 
+#define LIGHT 
+ 
+#ifdef RWSPINLOCK 
 #include <library/cpp/lwtrace/rwspinlock.h>
-#endif
-
-#define CHECK_LOGIC 1
-#define LOOPCOUNT 1000000
-#define RANRCOUNT 100
-#define THREADCOUNT 40
-#define WRITELOCKS 100
-
-#if defined(_MSC_VER)
-static int Y_FORCE_INLINE AtomicFetchAdd(volatile int& item, int value) {
-    return _InterlockedExchangeAdd((&item, value);
-}
-#elif defined(__GNUC__)
-#else
+#endif 
+ 
+#define CHECK_LOGIC 1 
+#define LOOPCOUNT 1000000 
+#define RANRCOUNT 100 
+#define THREADCOUNT 40 
+#define WRITELOCKS 100 
+ 
+#if defined(_MSC_VER) 
+static int Y_FORCE_INLINE AtomicFetchAdd(volatile int& item, int value) { 
+    return _InterlockedExchangeAdd((&item, value); 
+} 
+#elif defined(__GNUC__) 
+#else 
 #error unsupported platform
-#endif
-
-class TPosixRWLock {
-public:
-    TPosixRWLock() {
-    }
-
-    ~TPosixRWLock() {
-        pthread_rwlock_destroy(&rwlock);
-    }
-
-    TPosixRWLock(const TPosixRWLock&) = delete;
-    void operator=(const TPosixRWLock&) = delete;
-
-private:
-    pthread_rwlock_t rwlock = PTHREAD_RWLOCK_INITIALIZER;
-    friend class TPosixRWShareLocker;
-    friend class TPosixRWExclusiveLocker;
-};
-
-#if defined(LIGHT)
-TLightRWLock __attribute__((aligned(64))) rwlock;
-#elif defined(POSIX)
-TPosixRWLock rwlock;
-#elif defined(RWSPINLOCK)
-TRWSpinLock __attribute__((aligned(64))) rwlock;
-#else
-#error "define lock type"
-#endif
-
-volatile __attribute__((aligned(64))) int checkIt = 0;
-volatile int checkExcl = 0;
-
-class TPosixRWShareLocker {
-public:
-    TPosixRWShareLocker(TPosixRWLock& lock)
-        : LockP_(&lock)
-    {
-        pthread_rwlock_rdlock(&LockP_->rwlock);
-    }
-
-    ~TPosixRWShareLocker() {
-        pthread_rwlock_unlock(&LockP_->rwlock);
-    }
-
-    TPosixRWShareLocker(const TPosixRWShareLocker&) = delete;
-    void operator=(const TPosixRWShareLocker&) = delete;
-
-private:
-    TPosixRWLock* LockP_;
-};
-
-class TPosixRWExclusiveLocker {
-public:
-    TPosixRWExclusiveLocker(TPosixRWLock& lock)
-        : LockP_(&lock)
-    {
-        pthread_rwlock_wrlock(&LockP_->rwlock);
-    }
-
-    ~TPosixRWExclusiveLocker() {
-        pthread_rwlock_unlock(&LockP_->rwlock);
-    }
-    TPosixRWExclusiveLocker(const TPosixRWExclusiveLocker&) = delete;
-    void operator=(const TPosixRWExclusiveLocker&) = delete;
-
-private:
-    TPosixRWLock* LockP_;
-};
-
-template <typename TLocker, bool excl>
-static Y_FORCE_INLINE void Run() {
-    TLocker lockIt(rwlock);
-
-#if defined(CHECK_LOGIC) && CHECK_LOGIC
-    if (!excl && checkExcl == 1) {
-        printf("there is a bug\n");
-    }
-
-    int result = AtomicFetchAdd(checkIt, 1);
-    if (excl)
-        checkExcl = 1;
-
-    if (excl && result > 1)
-        printf("there is a bug\n");
-#endif
-
-    for (unsigned w = 0; w < RANRCOUNT; ++w)
-        RandomNumber<ui32>();
-
-#if defined(CHECK_LOGIC) && CHECK_LOGIC
-    if (excl)
-        checkExcl = 0;
-
-    AtomicFetchAdd(checkIt, -1);
-#endif
-}
-
-#ifdef LIGHT
-static void* fast_thread_start(__attribute__((unused)) void* arg) {
-    for (unsigned q = 0; q < LOOPCOUNT; ++q) {
-        char excl = (RandomNumber<ui32>() % WRITELOCKS) == 0;
-        if (excl)
-            Run<TLightWriteGuard, 1>();
-        else
-            Run<TLightReadGuard, 0>();
-    }
-    return NULL;
-}
-#endif
-
-#ifdef POSIX
-static void* fast_thread_start(__attribute__((unused)) void* arg) {
-    for (unsigned q = 0; q < LOOPCOUNT; ++q) {
-        char excl = (RandomNumber<ui32>() % WRITELOCKS) == 0;
-        if (excl)
-            Run<TPosixRWExclusiveLocker, 1>();
-        else
-            Run<TPosixRWShareLocker, 0>();
-    }
-    return NULL;
-}
-#endif
-
-#ifdef RWSPINLOCK
-static void* fast_thread_start(__attribute__((unused)) void* arg) {
-    for (unsigned q = 0; q < LOOPCOUNT; ++q) {
-        char excl = (RandomNumber<ui32>() % WRITELOCKS) == 0;
-        if (excl)
-            Run<TWriteSpinLockGuard, 1>();
-        else
-            Run<TReadSpinLockGuard, 0>();
-    }
-    return NULL;
-}
-#endif
-
-int main() {
-    pthread_t threads[THREADCOUNT];
-
-    for (unsigned q = 0; q < THREADCOUNT; ++q) {
-        pthread_create(&(threads[q]), NULL, &fast_thread_start, NULL);
-    }
-
-    for (unsigned q = 0; q < THREADCOUNT; ++q)
-        pthread_join(threads[q], NULL);
-
-    return 0;
-}
-
-#else // !_linux_
-
-int main() {
-    return 0;
-}
-
-#endif
+#endif 
+ 
+class TPosixRWLock { 
+public: 
+    TPosixRWLock() { 
+    } 
+ 
+    ~TPosixRWLock() { 
+        pthread_rwlock_destroy(&rwlock); 
+    } 
+ 
+    TPosixRWLock(const TPosixRWLock&) = delete; 
+    void operator=(const TPosixRWLock&) = delete; 
+ 
+private: 
+    pthread_rwlock_t rwlock = PTHREAD_RWLOCK_INITIALIZER; 
+    friend class TPosixRWShareLocker; 
+    friend class TPosixRWExclusiveLocker; 
+}; 
+ 
+#if defined(LIGHT) 
+TLightRWLock __attribute__((aligned(64))) rwlock; 
+#elif defined(POSIX) 
+TPosixRWLock rwlock; 
+#elif defined(RWSPINLOCK) 
+TRWSpinLock __attribute__((aligned(64))) rwlock; 
+#else 
+#error "define lock type" 
+#endif 
+ 
+volatile __attribute__((aligned(64))) int checkIt = 0; 
+volatile int checkExcl = 0; 
+ 
+class TPosixRWShareLocker { 
+public: 
+    TPosixRWShareLocker(TPosixRWLock& lock) 
+        : LockP_(&lock) 
+    { 
+        pthread_rwlock_rdlock(&LockP_->rwlock); 
+    } 
+ 
+    ~TPosixRWShareLocker() { 
+        pthread_rwlock_unlock(&LockP_->rwlock); 
+    } 
+ 
+    TPosixRWShareLocker(const TPosixRWShareLocker&) = delete; 
+    void operator=(const TPosixRWShareLocker&) = delete; 
+ 
+private: 
+    TPosixRWLock* LockP_; 
+}; 
+ 
+class TPosixRWExclusiveLocker { 
+public: 
+    TPosixRWExclusiveLocker(TPosixRWLock& lock) 
+        : LockP_(&lock) 
+    { 
+        pthread_rwlock_wrlock(&LockP_->rwlock); 
+    } 
+ 
+    ~TPosixRWExclusiveLocker() { 
+        pthread_rwlock_unlock(&LockP_->rwlock); 
+    } 
+    TPosixRWExclusiveLocker(const TPosixRWExclusiveLocker&) = delete; 
+    void operator=(const TPosixRWExclusiveLocker&) = delete; 
+ 
+private: 
+    TPosixRWLock* LockP_; 
+}; 
+ 
+template <typename TLocker, bool excl> 
+static Y_FORCE_INLINE void Run() { 
+    TLocker lockIt(rwlock); 
+ 
+#if defined(CHECK_LOGIC) && CHECK_LOGIC 
+    if (!excl && checkExcl == 1) { 
+        printf("there is a bug\n"); 
+    } 
+ 
+    int result = AtomicFetchAdd(checkIt, 1); 
+    if (excl) 
+        checkExcl = 1; 
+ 
+    if (excl && result > 1) 
+        printf("there is a bug\n"); 
+#endif 
+ 
+    for (unsigned w = 0; w < RANRCOUNT; ++w) 
+        RandomNumber<ui32>(); 
+ 
+#if defined(CHECK_LOGIC) && CHECK_LOGIC 
+    if (excl) 
+        checkExcl = 0; 
+ 
+    AtomicFetchAdd(checkIt, -1); 
+#endif 
+} 
+ 
+#ifdef LIGHT 
+static void* fast_thread_start(__attribute__((unused)) void* arg) { 
+    for (unsigned q = 0; q < LOOPCOUNT; ++q) { 
+        char excl = (RandomNumber<ui32>() % WRITELOCKS) == 0; 
+        if (excl) 
+            Run<TLightWriteGuard, 1>(); 
+        else 
+            Run<TLightReadGuard, 0>(); 
+    } 
+    return NULL; 
+} 
+#endif 
+ 
+#ifdef POSIX 
+static void* fast_thread_start(__attribute__((unused)) void* arg) { 
+    for (unsigned q = 0; q < LOOPCOUNT; ++q) { 
+        char excl = (RandomNumber<ui32>() % WRITELOCKS) == 0; 
+        if (excl) 
+            Run<TPosixRWExclusiveLocker, 1>(); 
+        else 
+            Run<TPosixRWShareLocker, 0>(); 
+    } 
+    return NULL; 
+} 
+#endif 
+ 
+#ifdef RWSPINLOCK 
+static void* fast_thread_start(__attribute__((unused)) void* arg) { 
+    for (unsigned q = 0; q < LOOPCOUNT; ++q) { 
+        char excl = (RandomNumber<ui32>() % WRITELOCKS) == 0; 
+        if (excl) 
+            Run<TWriteSpinLockGuard, 1>(); 
+        else 
+            Run<TReadSpinLockGuard, 0>(); 
+    } 
+    return NULL; 
+} 
+#endif 
+ 
+int main() { 
+    pthread_t threads[THREADCOUNT]; 
+ 
+    for (unsigned q = 0; q < THREADCOUNT; ++q) { 
+        pthread_create(&(threads[q]), NULL, &fast_thread_start, NULL); 
+    } 
+ 
+    for (unsigned q = 0; q < THREADCOUNT; ++q) 
+        pthread_join(threads[q], NULL); 
+ 
+    return 0; 
+} 
+ 
+#else // !_linux_ 
+ 
+int main() { 
+    return 0; 
+} 
+ 
+#endif 
diff --git a/library/cpp/threading/light_rw_lock/bench/ya.make b/library/cpp/threading/light_rw_lock/bench/ya.make
index 7969b52a50..ed89e3a9b0 100644
--- a/library/cpp/threading/light_rw_lock/bench/ya.make
+++ b/library/cpp/threading/light_rw_lock/bench/ya.make
@@ -1,13 +1,13 @@
-PROGRAM(lightrwlock_test)
-
-OWNER(agri)
-
-SRCS(
-    lightrwlock_test.cpp
-)
-
-PEERDIR(
+PROGRAM(lightrwlock_test) 
+ 
+OWNER(agri) 
+ 
+SRCS( 
+    lightrwlock_test.cpp 
+) 
+ 
+PEERDIR( 
     library/cpp/threading/light_rw_lock
-)
-
-END()
+) 
+ 
+END()