aboutsummaryrefslogtreecommitdiffstats
path: root/util/thread/lfstack_ut.cpp
diff options
context:
space:
mode:
authorVlad Yaroslavlev <vladon@vladon.com>2022-02-10 16:46:23 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:46:23 +0300
commit706b83ed7de5a473436620367af31fc0ceecde07 (patch)
tree103305d30dec77e8f6367753367f59b3cd68f9f1 /util/thread/lfstack_ut.cpp
parent918e8a1574070d0ec733f0b76cfad8f8892ad2e5 (diff)
downloadydb-706b83ed7de5a473436620367af31fc0ceecde07.tar.gz
Restoring authorship annotation for Vlad Yaroslavlev <vladon@vladon.com>. Commit 1 of 2.
Diffstat (limited to 'util/thread/lfstack_ut.cpp')
-rw-r--r--util/thread/lfstack_ut.cpp16
1 files changed, 8 insertions, 8 deletions
diff --git a/util/thread/lfstack_ut.cpp b/util/thread/lfstack_ut.cpp
index e20a838f95b..61edd3d632e 100644
--- a/util/thread/lfstack_ut.cpp
+++ b/util/thread/lfstack_ut.cpp
@@ -68,7 +68,7 @@ Y_UNIT_TEST_SUITE(TLockFreeStackTests) {
StartLatch.CountDown();
StartLatch.Await();
- TVector<int> temp;
+ TVector<int> temp;
while (AtomicGet(LeftToDequeue) > 0) {
size_t dequeued = 0;
for (size_t i = 0; i < 100; ++i) {
@@ -85,7 +85,7 @@ Y_UNIT_TEST_SUITE(TLockFreeStackTests) {
}
void Run() {
- TVector<TSimpleSharedPtr<NThreading::TLegacyFuture<>>> futures;
+ TVector<TSimpleSharedPtr<NThreading::TLegacyFuture<>>> futures;
for (size_t i = 0; i < EnqueueThreads; ++i) {
futures.push_back(new NThreading::TLegacyFuture<>(std::bind(&TDequeueAllTester<SingleConsumer>::Enqueuer, this)));
@@ -100,7 +100,7 @@ Y_UNIT_TEST_SUITE(TLockFreeStackTests) {
UNIT_ASSERT_VALUES_EQUAL(0, int(AtomicGet(LeftToDequeue)));
- TVector<int> left;
+ TVector<int> left;
Stack.DequeueAll(&left);
UNIT_ASSERT(left.empty());
}
@@ -117,7 +117,7 @@ Y_UNIT_TEST_SUITE(TLockFreeStackTests) {
Y_UNIT_TEST(TestDequeueAllEmptyStack) {
TLockFreeStack<int> stack;
- TVector<int> r;
+ TVector<int> r;
stack.DequeueAll(&r);
UNIT_ASSERT(r.empty());
@@ -130,7 +130,7 @@ Y_UNIT_TEST_SUITE(TLockFreeStackTests) {
stack.Enqueue(19);
stack.Enqueue(23);
- TVector<int> r;
+ TVector<int> r;
stack.DequeueAll(&r);
@@ -143,8 +143,8 @@ Y_UNIT_TEST_SUITE(TLockFreeStackTests) {
Y_UNIT_TEST(TestEnqueueAll) {
TLockFreeStack<int> stack;
- TVector<int> v;
- TVector<int> expected;
+ TVector<int> v;
+ TVector<int> expected;
stack.EnqueueAll(v); // add empty
@@ -165,7 +165,7 @@ Y_UNIT_TEST_SUITE(TLockFreeStackTests) {
expected.insert(expected.end(), v.begin(), v.end());
stack.EnqueueAll(v);
- TVector<int> actual;
+ TVector<int> actual;
stack.DequeueAll(&actual);
UNIT_ASSERT_VALUES_EQUAL(expected.size(), actual.size());