aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus/actor
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 /library/cpp/messagebus/actor
parent918e8a1574070d0ec733f0b76cfad8f8892ad2e5 (diff)
downloadydb-706b83ed7de5a473436620367af31fc0ceecde07.tar.gz
Restoring authorship annotation for Vlad Yaroslavlev <vladon@vladon.com>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/messagebus/actor')
-rw-r--r--library/cpp/messagebus/actor/executor.cpp4
-rw-r--r--library/cpp/messagebus/actor/ring_buffer.h4
-rw-r--r--library/cpp/messagebus/actor/temp_tls_vector.h8
-rw-r--r--library/cpp/messagebus/actor/thread_extra.cpp6
4 files changed, 11 insertions, 11 deletions
diff --git a/library/cpp/messagebus/actor/executor.cpp b/library/cpp/messagebus/actor/executor.cpp
index 7a2227a458..eaf0751709 100644
--- a/library/cpp/messagebus/actor/executor.cpp
+++ b/library/cpp/messagebus/actor/executor.cpp
@@ -249,11 +249,11 @@ ui32 TExecutor::GetMaxQueueSizeAndClear() const {
return max;
}
-TString TExecutor::GetStatus() const {
+TString TExecutor::GetStatus() const {
return GetStatusRecordInternal().Status;
}
-TString TExecutor::GetStatusSingleLine() const {
+TString TExecutor::GetStatusSingleLine() const {
TStringStream ss;
ss << "work items: " << GetWorkQueueSize();
return ss.Str();
diff --git a/library/cpp/messagebus/actor/ring_buffer.h b/library/cpp/messagebus/actor/ring_buffer.h
index ec5706f7c7..937d8d5a3d 100644
--- a/library/cpp/messagebus/actor/ring_buffer.h
+++ b/library/cpp/messagebus/actor/ring_buffer.h
@@ -14,7 +14,7 @@ private:
ui32 Capacity;
ui32 WritePos;
ui32 ReadPos;
- TVector<T> Data;
+ TVector<T> Data;
void StateCheck() const {
Y_ASSERT(Capacity == Data.size());
@@ -39,7 +39,7 @@ private:
}
ui32 newCapacity = 1u << newCapacityPow;
ui32 newCapacityMask = newCapacity - 1u;
- TVector<T> newData(newCapacity);
+ TVector<T> newData(newCapacity);
ui32 oldSize = Size();
// Copy old elements
for (size_t i = 0; i < oldSize; ++i) {
diff --git a/library/cpp/messagebus/actor/temp_tls_vector.h b/library/cpp/messagebus/actor/temp_tls_vector.h
index 675d92f5b0..7d9fbce088 100644
--- a/library/cpp/messagebus/actor/temp_tls_vector.h
+++ b/library/cpp/messagebus/actor/temp_tls_vector.h
@@ -10,15 +10,15 @@ class TTempTlsVector {
private:
struct TTagForTls {};
- TVectorType<T, std::allocator<T>>* Vector;
+ TVectorType<T, std::allocator<T>>* Vector;
public:
- TVectorType<T, std::allocator<T>>* GetVector() {
+ TVectorType<T, std::allocator<T>>* GetVector() {
return Vector;
}
TTempTlsVector() {
- Vector = FastTlsSingletonWithTag<TVectorType<T, std::allocator<T>>, TTagForTls>();
+ Vector = FastTlsSingletonWithTag<TVectorType<T, std::allocator<T>>, TTagForTls>();
Y_ASSERT(Vector->empty());
}
@@ -30,7 +30,7 @@ public:
Vector->clear();
}
- size_t Capacity() const noexcept {
+ size_t Capacity() const noexcept {
return Vector->capacity();
}
diff --git a/library/cpp/messagebus/actor/thread_extra.cpp b/library/cpp/messagebus/actor/thread_extra.cpp
index 048480f255..826ae45670 100644
--- a/library/cpp/messagebus/actor/thread_extra.cpp
+++ b/library/cpp/messagebus/actor/thread_extra.cpp
@@ -7,10 +7,10 @@
namespace {
#ifdef _linux_
- TString GetExecName() {
- TString execPath = GetExecPath();
+ TString GetExecName() {
+ TString execPath = GetExecPath();
size_t lastSlash = execPath.find_last_of('/');
- if (lastSlash == TString::npos) {
+ if (lastSlash == TString::npos) {
return execPath;
} else {
return execPath.substr(lastSlash + 1);