aboutsummaryrefslogtreecommitdiffstats
path: root/util/thread
diff options
context:
space:
mode:
authororivej <orivej@yandex-team.ru>2022-02-10 16:45:01 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:45:01 +0300
commit2d37894b1b037cf24231090eda8589bbb44fb6fc (patch)
treebe835aa92c6248212e705f25388ebafcf84bc7a1 /util/thread
parent718c552901d703c502ccbefdfc3c9028d608b947 (diff)
downloadydb-2d37894b1b037cf24231090eda8589bbb44fb6fc.tar.gz
Restoring authorship annotation for <orivej@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'util/thread')
-rw-r--r--util/thread/lfstack.h10
1 files changed, 5 insertions, 5 deletions
diff --git a/util/thread/lfstack.h b/util/thread/lfstack.h
index b94bf11b48..ca3d95f3c3 100644
--- a/util/thread/lfstack.h
+++ b/util/thread/lfstack.h
@@ -35,14 +35,14 @@ class TLockFreeStack: TNonCopyable {
EraseList(current);
}
}
- void EraseList(TNode* volatile p) {
+ void EraseList(TNode* volatile p) {
while (p) {
TNode* next = p->Next;
delete p;
p = next;
}
}
- void EnqueueImpl(TNode* volatile head, TNode* volatile tail) {
+ void EnqueueImpl(TNode* volatile head, TNode* volatile tail) {
for (;;) {
tail->Next = AtomicGet(Head);
if (AtomicCas(&Head, head, tail->Next))
@@ -51,7 +51,7 @@ class TLockFreeStack: TNonCopyable {
}
template <class U>
void EnqueueImpl(U&& u) {
- TNode* volatile node = new TNode(std::forward<U>(u));
+ TNode* volatile node = new TNode(std::forward<U>(u));
EnqueueImpl(node, node);
}
@@ -85,8 +85,8 @@ public:
return;
}
TIter i = dataBegin;
- TNode* volatile node = new TNode(*i);
- TNode* volatile tail = node;
+ TNode* volatile node = new TNode(*i);
+ TNode* volatile tail = node;
for (++i; i != dataEnd; ++i) {
TNode* nextNode = node;