diff options
author | Anton Samokhvalov <pg83@yandex.ru> | 2022-02-10 16:45:15 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:45:15 +0300 |
commit | 72cb13b4aff9bc9cf22e49251bc8fd143f82538f (patch) | |
tree | da2c34829458c7d4e74bdfbdf85dff449e9e7fb8 /util/thread/lfqueue_ut.cpp | |
parent | 778e51ba091dc39e7b7fcab2b9cf4dbedfb6f2b5 (diff) | |
download | ydb-72cb13b4aff9bc9cf22e49251bc8fd143f82538f.tar.gz |
Restoring authorship annotation for Anton Samokhvalov <pg83@yandex.ru>. Commit 1 of 2.
Diffstat (limited to 'util/thread/lfqueue_ut.cpp')
-rw-r--r-- | util/thread/lfqueue_ut.cpp | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/util/thread/lfqueue_ut.cpp b/util/thread/lfqueue_ut.cpp index 83bca100cf..1290ce0a46 100644 --- a/util/thread/lfqueue_ut.cpp +++ b/util/thread/lfqueue_ut.cpp @@ -7,7 +7,7 @@ #include <util/system/atomic.h> #include <util/thread/pool.h> -#include "lfqueue.h" +#include "lfqueue.h" class TMoveTest { public: @@ -54,24 +54,24 @@ private: class TOperationsChecker { public: TOperationsChecker() { - ++DefaultCtor_; + ++DefaultCtor_; } TOperationsChecker(TOperationsChecker&&) { - ++MoveCtor_; + ++MoveCtor_; } TOperationsChecker(const TOperationsChecker&) { - ++CopyCtor_; + ++CopyCtor_; } TOperationsChecker& operator=(TOperationsChecker&&) { - ++MoveAssign_; + ++MoveAssign_; return *this; } TOperationsChecker& operator=(const TOperationsChecker&) { - ++CopyAssign_; + ++CopyAssign_; return *this; } @@ -190,7 +190,7 @@ Y_UNIT_TEST_SUITE(TLockFreeQueueTests) { UNIT_ASSERT(!queue.Dequeue(&i)); } - void DequeueAllRunner(TLockFreeQueue<int>& queue, bool singleConsumer) { + void DequeueAllRunner(TLockFreeQueue<int>& queue, bool singleConsumer) { size_t threadsNum = 4; size_t enqueuesPerThread = 10'000; TThreadPool p; @@ -303,11 +303,11 @@ Y_UNIT_TEST_SUITE(TLockFreeQueueTests) { } Y_UNIT_TEST(CleanInDestructor) { - TSimpleSharedPtr<bool> p(new bool); + TSimpleSharedPtr<bool> p(new bool); UNIT_ASSERT_VALUES_EQUAL(1u, p.RefCount()); { - TLockFreeQueue<TSimpleSharedPtr<bool>> stack; + TLockFreeQueue<TSimpleSharedPtr<bool>> stack; stack.Enqueue(p); stack.Enqueue(p); |