aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/threading/queue
diff options
context:
space:
mode:
authoryazevnul <yazevnul@yandex-team.ru>2022-02-10 16:46:48 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:46:48 +0300
commit9abfb1a53b7f7b791444d1378e645d8fad9b06ed (patch)
tree49e222ea1c5804306084bb3ae065bb702625360f /library/cpp/threading/queue
parent8cbc307de0221f84c80c42dcbe07d40727537e2c (diff)
downloadydb-9abfb1a53b7f7b791444d1378e645d8fad9b06ed.tar.gz
Restoring authorship annotation for <yazevnul@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/threading/queue')
-rw-r--r--library/cpp/threading/queue/basic_ut.cpp2
-rw-r--r--library/cpp/threading/queue/queue_ut.cpp8
-rw-r--r--library/cpp/threading/queue/tune_ut.cpp12
-rw-r--r--library/cpp/threading/queue/unordered_ut.cpp2
4 files changed, 12 insertions, 12 deletions
diff --git a/library/cpp/threading/queue/basic_ut.cpp b/library/cpp/threading/queue/basic_ut.cpp
index a52b46c8a6..5f56f8583e 100644
--- a/library/cpp/threading/queue/basic_ut.cpp
+++ b/library/cpp/threading/queue/basic_ut.cpp
@@ -51,7 +51,7 @@ public:
template <size_t NUMBER_OF_THREADS>
void RepeatPush1Pop1_InManyThreads() {
- class TCycleThread: public ISimpleThread {
+ class TCycleThread: public ISimpleThread {
public:
void* ThreadProc() override {
TQueueType queue;
diff --git a/library/cpp/threading/queue/queue_ut.cpp b/library/cpp/threading/queue/queue_ut.cpp
index eb77e51e19..80eca147da 100644
--- a/library/cpp/threading/queue/queue_ut.cpp
+++ b/library/cpp/threading/queue/queue_ut.cpp
@@ -43,7 +43,7 @@ public:
void Threads2_Push1M_Threads1_Pop2M() {
TQueueType queue;
- class TPusherThread: public ISimpleThread {
+ class TPusherThread: public ISimpleThread {
public:
TPusherThread(TQueueType& theQueue, char* start)
: Queue(theQueue)
@@ -81,7 +81,7 @@ public:
void Threads4_Push1M_Threads1_Pop4M() {
TQueueType queue;
- class TPusherThread: public ISimpleThread {
+ class TPusherThread: public ISimpleThread {
public:
TPusherThread(TQueueType& theQueue, char* start)
: Queue(theQueue)
@@ -124,7 +124,7 @@ public:
void ManyRndPush100K_ManyQueues() {
TQueueType queue[NUMBER_OF_QUEUES];
- class TPusherThread: public ISimpleThread {
+ class TPusherThread: public ISimpleThread {
public:
TPusherThread(TQueueType* queues, char* start)
: Queues(queues)
@@ -155,7 +155,7 @@ public:
}
};
- class TPopperThread: public ISimpleThread {
+ class TPopperThread: public ISimpleThread {
public:
TPopperThread(TQueueType* theQueue, char* base)
: Queue(theQueue)
diff --git a/library/cpp/threading/queue/tune_ut.cpp b/library/cpp/threading/queue/tune_ut.cpp
index 34086ccf0f..7e980d3e27 100644
--- a/library/cpp/threading/queue/tune_ut.cpp
+++ b/library/cpp/threading/queue/tune_ut.cpp
@@ -19,8 +19,8 @@ DeclareTuneTypeParam(TweakStructB, TStructB);
DeclareTuneValueParam(TweakParam1, ui32, Param1);
DeclareTuneValueParam(TweakParam2, ui32, Param2);
-Y_UNIT_TEST_SUITE(TestTuning) {
- Y_UNIT_TEST(Defaults) {
+Y_UNIT_TEST_SUITE(TestTuning) {
+ Y_UNIT_TEST(Defaults) {
using TTuned = TTune<TDefaults>;
using TunedA = TTuned::TStructA;
using TunedB = TTuned::TStructB;
@@ -35,7 +35,7 @@ Y_UNIT_TEST_SUITE(TestTuning) {
UNIT_ASSERT_EQUAL(param2, 42);
}
- Y_UNIT_TEST(TuneStructA) {
+ Y_UNIT_TEST(TuneStructA) {
struct TMyStruct {
};
@@ -56,7 +56,7 @@ Y_UNIT_TEST_SUITE(TestTuning) {
UNIT_ASSERT_EQUAL(param2, 42);
}
- Y_UNIT_TEST(TuneParam1) {
+ Y_UNIT_TEST(TuneParam1) {
using TTuned = TTune<TDefaults, TweakParam1<24>>;
using TunedA = TTuned::TStructA;
@@ -72,7 +72,7 @@ Y_UNIT_TEST_SUITE(TestTuning) {
UNIT_ASSERT_EQUAL(param2, 42);
}
- Y_UNIT_TEST(TuneStructAAndParam1) {
+ Y_UNIT_TEST(TuneStructAAndParam1) {
struct TMyStruct {
};
@@ -94,7 +94,7 @@ Y_UNIT_TEST_SUITE(TestTuning) {
UNIT_ASSERT_EQUAL(param2, 42);
}
- Y_UNIT_TEST(TuneParam1AndStructA) {
+ Y_UNIT_TEST(TuneParam1AndStructA) {
struct TMyStruct {
};
diff --git a/library/cpp/threading/queue/unordered_ut.cpp b/library/cpp/threading/queue/unordered_ut.cpp
index 1310559c46..a43b7f520e 100644
--- a/library/cpp/threading/queue/unordered_ut.cpp
+++ b/library/cpp/threading/queue/unordered_ut.cpp
@@ -56,7 +56,7 @@ public:
void ManyThreadsRndExchange() {
TQueueType queues[COUNT];
- class TWorker: public ISimpleThread {
+ class TWorker: public ISimpleThread {
public:
TWorker(
TQueueType* queues_,