diff options
| author | arcadia-devtools <arcadia-devtools@yandex-team.ru> | 2022-02-10 16:48:02 +0300 |
|---|---|---|
| committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:48:02 +0300 |
| commit | 659131349be7796c633c453b4d8b4fa20b8c6ee9 (patch) | |
| tree | 67ae2197ea6054b7c46901db060a27fa94377631 /util/thread/lfqueue.h | |
| parent | a8b9b8cf5b7405ae170a24f8e1fc27efd8b0849b (diff) | |
| download | ydb-659131349be7796c633c453b4d8b4fa20b8c6ee9.tar.gz | |
Restoring authorship annotation for <arcadia-devtools@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'util/thread/lfqueue.h')
| -rw-r--r-- | util/thread/lfqueue.h | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/util/thread/lfqueue.h b/util/thread/lfqueue.h index ab523631e4..07b1351624 100644 --- a/util/thread/lfqueue.h +++ b/util/thread/lfqueue.h @@ -70,10 +70,10 @@ class TLockFreeQueue: public TNonCopyable { } } - alignas(64) TRootNode* volatile JobQueue; - alignas(64) volatile TAtomic FreememCounter; - alignas(64) volatile TAtomic FreeingTaskCounter; - alignas(64) TRootNode* volatile FreePtr; + alignas(64) TRootNode* volatile JobQueue; + alignas(64) volatile TAtomic FreememCounter; + alignas(64) volatile TAtomic FreeingTaskCounter; + alignas(64) TRootNode* volatile FreePtr; void TryToFreeAsyncMemory() { TAtomic keepCounter = AtomicAdd(FreeingTaskCounter, 0); @@ -306,7 +306,7 @@ public: newRoot = new TRootNode; AtomicSet(newRoot->PushQueue, nullptr); listInvertor.DoCopy(AtomicGet(curRoot->PushQueue)); - AtomicSet(newRoot->PopQueue, listInvertor.Copy); + AtomicSet(newRoot->PopQueue, listInvertor.Copy); newRoot->CopyCounter(curRoot); Y_ASSERT(AtomicGet(curRoot->PopQueue) == nullptr); if (AtomicCas(&JobQueue, newRoot, curRoot)) { |