aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/threading/equeue/equeue_ut.cpp
diff options
context:
space:
mode:
authortobo <tobo@yandex-team.ru>2022-02-10 16:47:27 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:47:27 +0300
commit7fe839092527589b38f014d854c51565b3c1adfa (patch)
tree309e97022d3530044b712b8f71318c78faf7856e /library/cpp/threading/equeue/equeue_ut.cpp
parentd0d68c395c10da4cb56a1c845504570a04d7893e (diff)
downloadydb-7fe839092527589b38f014d854c51565b3c1adfa.tar.gz
Restoring authorship annotation for <tobo@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/threading/equeue/equeue_ut.cpp')
-rw-r--r--library/cpp/threading/equeue/equeue_ut.cpp6
1 files changed, 3 insertions, 3 deletions
diff --git a/library/cpp/threading/equeue/equeue_ut.cpp b/library/cpp/threading/equeue/equeue_ut.cpp
index 9cf2aced44..5ff4c69347 100644
--- a/library/cpp/threading/equeue/equeue_ut.cpp
+++ b/library/cpp/threading/equeue/equeue_ut.cpp
@@ -41,7 +41,7 @@ Y_UNIT_TEST_SUITE(TElasticQueueTest) {
Counters.Reset();
struct TWaitJob: public IObjectInQueue {
- void Process(void*) override {
+ void Process(void*) override {
WaitEvent.Wait();
AtomicIncrement(Counters.Processed);
}
@@ -72,7 +72,7 @@ Y_UNIT_TEST_SUITE(TElasticQueueTest) {
//concurrent test -- send many jobs from different threads
struct TJob: public IObjectInQueue {
- void Process(void*) override {
+ void Process(void*) override {
AtomicIncrement(Counters.Processed);
};
};
@@ -96,7 +96,7 @@ Y_UNIT_TEST_SUITE(TElasticQueueTest) {
TryCounter = 0;
struct TSender: public IThreadFactory::IThreadAble {
- void DoExecute() override {
+ void DoExecute() override {
while ((size_t)AtomicIncrement(TryCounter) <= N) {
if (!TryAdd()) {
Sleep(TDuration::MicroSeconds(50));