aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus
diff options
context:
space:
mode:
authorAndrey Khalyavin <halyavin@gmail.com>2022-02-10 16:46:30 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:46:30 +0300
commit4b839d0704ee9be1dabb0310a1f03af24963637b (patch)
tree1a2c5ffcf89eb53ecd79dbc9bc0a195c27404d0c /library/cpp/messagebus
parentf773626848a7c7456803654292e716b83d69cc12 (diff)
downloadydb-4b839d0704ee9be1dabb0310a1f03af24963637b.tar.gz
Restoring authorship annotation for Andrey Khalyavin <halyavin@gmail.com>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/messagebus')
-rw-r--r--library/cpp/messagebus/actor/executor.cpp6
-rw-r--r--library/cpp/messagebus/duration_histogram.cpp2
-rw-r--r--library/cpp/messagebus/duration_histogram.h6
-rw-r--r--library/cpp/messagebus/key_value_printer.h2
-rw-r--r--library/cpp/messagebus/message_status_counter.h4
-rw-r--r--library/cpp/messagebus/protobuf/ybusbuf.h2
-rw-r--r--library/cpp/messagebus/rain_check/core/spawn_ut.cpp4
-rw-r--r--library/cpp/messagebus/rain_check/test/helper/misc.h6
-rw-r--r--library/cpp/messagebus/rain_check/test/perftest/perftest.cpp8
-rw-r--r--library/cpp/messagebus/www/www.cpp6
10 files changed, 23 insertions, 23 deletions
diff --git a/library/cpp/messagebus/actor/executor.cpp b/library/cpp/messagebus/actor/executor.cpp
index fb6c548089..7a2227a458 100644
--- a/library/cpp/messagebus/actor/executor.cpp
+++ b/library/cpp/messagebus/actor/executor.cpp
@@ -10,8 +10,8 @@
#include <util/system/tls.h>
#include <util/system/yassert.h>
-#include <array>
-
+#include <array>
+
using namespace NActor;
using namespace NActor::NPrivate;
@@ -35,7 +35,7 @@ namespace {
ui64 Start;
ui64 LastTime;
- std::array<TRecord, 3600> Records;
+ std::array<TRecord, 3600> Records;
THistoryInternal() {
Start = TInstant::Now().Seconds();
diff --git a/library/cpp/messagebus/duration_histogram.cpp b/library/cpp/messagebus/duration_histogram.cpp
index 366372907d..32a0001d41 100644
--- a/library/cpp/messagebus/duration_histogram.cpp
+++ b/library/cpp/messagebus/duration_histogram.cpp
@@ -32,7 +32,7 @@ namespace {
namespace {
struct TMarks {
- std::array<TDuration, TDurationHistogram::Buckets> Marks;
+ std::array<TDuration, TDurationHistogram::Buckets> Marks;
TMarks() {
Marks[0] = TDuration::Zero();
diff --git a/library/cpp/messagebus/duration_histogram.h b/library/cpp/messagebus/duration_histogram.h
index ea5a423eaf..ed060b0101 100644
--- a/library/cpp/messagebus/duration_histogram.h
+++ b/library/cpp/messagebus/duration_histogram.h
@@ -4,16 +4,16 @@
#include <util/generic/bitops.h>
#include <util/generic/string.h>
-#include <array>
+#include <array>
struct TDurationHistogram {
static const unsigned Buckets = 20;
- std::array<ui64, Buckets> Times;
+ std::array<ui64, Buckets> Times;
static const unsigned SecondBoundary = 11;
TDurationHistogram() {
- Times.fill(0);
+ Times.fill(0);
}
static unsigned BucketFor(TDuration d) {
diff --git a/library/cpp/messagebus/key_value_printer.h b/library/cpp/messagebus/key_value_printer.h
index 385b6e0960..bca1fde50e 100644
--- a/library/cpp/messagebus/key_value_printer.h
+++ b/library/cpp/messagebus/key_value_printer.h
@@ -17,7 +17,7 @@ public:
~TKeyValuePrinter();
template <typename TKey, typename TValue>
- void AddRow(const TKey& key, const TValue& value, bool leftAlign = !std::is_integral<TValue>::value) {
+ void AddRow(const TKey& key, const TValue& value, bool leftAlign = !std::is_integral<TValue>::value) {
return AddRowImpl(ToString(key), ToString(value), leftAlign);
}
diff --git a/library/cpp/messagebus/message_status_counter.h b/library/cpp/messagebus/message_status_counter.h
index a935ab9b75..e8ba2fdd31 100644
--- a/library/cpp/messagebus/message_status_counter.h
+++ b/library/cpp/messagebus/message_status_counter.h
@@ -6,7 +6,7 @@
#include <util/generic/string.h>
-#include <array>
+#include <array>
namespace NBus {
namespace NPrivate {
@@ -14,7 +14,7 @@ namespace NBus {
static TMessageStatusRecord::EMessageStatus MessageStatusToProtobuf(EMessageStatus status) {
return (TMessageStatusRecord::EMessageStatus)status;
}
-
+
std::array<unsigned, MESSAGE_STATUS_COUNT> Counts;
unsigned& operator[](EMessageStatus index) {
diff --git a/library/cpp/messagebus/protobuf/ybusbuf.h b/library/cpp/messagebus/protobuf/ybusbuf.h
index 3a5fe4e2b7..57b4267ea5 100644
--- a/library/cpp/messagebus/protobuf/ybusbuf.h
+++ b/library/cpp/messagebus/protobuf/ybusbuf.h
@@ -9,7 +9,7 @@
#include <util/generic/vector.h>
#include <util/stream/mem.h>
-#include <array>
+#include <array>
namespace NBus {
using TBusBufferRecord = ::google::protobuf::Message;
diff --git a/library/cpp/messagebus/rain_check/core/spawn_ut.cpp b/library/cpp/messagebus/rain_check/core/spawn_ut.cpp
index 0435262b59..ba5a5e41cf 100644
--- a/library/cpp/messagebus/rain_check/core/spawn_ut.cpp
+++ b/library/cpp/messagebus/rain_check/core/spawn_ut.cpp
@@ -7,7 +7,7 @@
#include <util/system/event.h>
-#include <array>
+#include <array>
using namespace NRainCheck;
using namespace NActor;
@@ -116,7 +116,7 @@ Y_UNIT_TEST_SUITE(Spawn) {
{
}
- std::array<TSubtaskCompletion, 3> Subtasks;
+ std::array<TSubtaskCompletion, 3> Subtasks;
TContinueFunc Start() override {
if (I == 1000) {
diff --git a/library/cpp/messagebus/rain_check/test/helper/misc.h b/library/cpp/messagebus/rain_check/test/helper/misc.h
index 7b37051f49..9150be4d2f 100644
--- a/library/cpp/messagebus/rain_check/test/helper/misc.h
+++ b/library/cpp/messagebus/rain_check/test/helper/misc.h
@@ -2,7 +2,7 @@
#include <library/cpp/messagebus/rain_check/core/rain_check.h>
-#include <array>
+#include <array>
namespace NRainCheck {
struct TNopSimpleTask: public ISimpleTask {
@@ -32,7 +32,7 @@ namespace NRainCheck {
{
}
- std::array<TSubtaskCompletion, 2> Completion;
+ std::array<TSubtaskCompletion, 2> Completion;
void Run() override;
};
@@ -47,7 +47,7 @@ namespace NRainCheck {
{
}
- std::array<TSubtaskCompletion, 2> Completion;
+ std::array<TSubtaskCompletion, 2> Completion;
TContinueFunc Start() override;
diff --git a/library/cpp/messagebus/rain_check/test/perftest/perftest.cpp b/library/cpp/messagebus/rain_check/test/perftest/perftest.cpp
index d34ed1a8f8..22edbd8c6b 100644
--- a/library/cpp/messagebus/rain_check/test/perftest/perftest.cpp
+++ b/library/cpp/messagebus/rain_check/test/perftest/perftest.cpp
@@ -4,7 +4,7 @@
#include <util/datetime/base.h>
-#include <array>
+#include <array>
using namespace NRainCheck;
@@ -38,7 +38,7 @@ struct TCoroOuter: public ICoroTask {
do {
for (unsigned i = 0; i < current; ++i) {
- std::array<TSubtaskCompletion, SUBTASKS> completion;
+ std::array<TSubtaskCompletion, SUBTASKS> completion;
for (unsigned j = 0; j < SUBTASKS; ++j) {
//SpawnSubtask<TNopSimpleTask>(Env, &completion[j]);
@@ -82,7 +82,7 @@ struct TSimpleOuter: public ISimpleTask {
return &TSimpleOuter::Spawn;
}
- std::array<TSubtaskCompletion, SUBTASKS> Completion;
+ std::array<TSubtaskCompletion, SUBTASKS> Completion;
TContinueFunc Spawn() {
for (unsigned j = 0; j < SUBTASKS; ++j) {
@@ -124,7 +124,7 @@ struct TReproduceCrashTask: public ISimpleTask {
{
}
- std::array<TSubtaskCompletion, SUBTASKS> Completion;
+ std::array<TSubtaskCompletion, SUBTASKS> Completion;
TContinueFunc Start() override {
for (unsigned j = 0; j < 2; ++j) {
diff --git a/library/cpp/messagebus/www/www.cpp b/library/cpp/messagebus/www/www.cpp
index 33c5fa0ca0..62ec241d85 100644
--- a/library/cpp/messagebus/www/www.cpp
+++ b/library/cpp/messagebus/www/www.cpp
@@ -74,7 +74,7 @@ namespace {
TValuePtr current = FindByName(p->GetNameInternal());
if (!current) {
- Entries.emplace_back(p->GetNameInternal(), p);
+ Entries.emplace_back(p->GetNameInternal(), p);
return;
}
}
@@ -89,7 +89,7 @@ namespace {
TValuePtr current = FindByName(name);
if (!current) {
- Entries.emplace_back(name, p);
+ Entries.emplace_back(name, p);
return;
}
}
@@ -901,7 +901,7 @@ struct TBusWwwHttpServer::TImpl: public THttpServer::ICallBack {
cgiParams.Scan(url.Get(THttpURL::FieldQuery));
TBusWww::TOptionalParams params;
- //params.ParentLinks.emplace_back();
+ //params.ParentLinks.emplace_back();
//params.ParentLinks.back().Title = "temp";
//params.ParentLinks.back().Href = "http://wiki.yandex-team.ru/";