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 | a61e8c559b6b690a019253067224d595e3d642f1 (patch) | |
| tree | b222e5ac2e2e98872661c51ccceee5da0d291e13 /util/thread/lfqueue.h | |
| parent | 659131349be7796c633c453b4d8b4fa20b8c6ee9 (diff) | |
| download | ydb-a61e8c559b6b690a019253067224d595e3d642f1.tar.gz | |
Restoring authorship annotation for <arcadia-devtools@yandex-team.ru>. Commit 2 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 07b1351624..ab523631e4 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)) { |