summaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus/actor
diff options
context:
space:
mode:
authorVlad Yaroslavlev <[email protected]>2022-02-10 16:46:25 +0300
committerDaniil Cherednik <[email protected]>2022-02-10 16:46:25 +0300
commit344ea37b4a345701ab0e67de2266a1c1bd7baf2d (patch)
tree1a2c5ffcf89eb53ecd79dbc9bc0a195c27404d0c /library/cpp/messagebus/actor
parent706b83ed7de5a473436620367af31fc0ceecde07 (diff)
Restoring authorship annotation for Vlad Yaroslavlev <[email protected]>. Commit 2 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 eaf07517094..7a2227a4589 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 937d8d5a3db..ec5706f7c76 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 7d9fbce0887..675d92f5b0b 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 826ae45670d..048480f2553 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);