aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus/event_loop.cpp
diff options
context:
space:
mode:
authorvskipin <vskipin@yandex-team.ru>2022-02-10 16:46:00 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:46:00 +0300
commit4d8b546b89b5afc08cf3667e176271c7ba935f33 (patch)
tree1a2c5ffcf89eb53ecd79dbc9bc0a195c27404d0c /library/cpp/messagebus/event_loop.cpp
parent4e4b78bd7b67e2533da4dbb9696374a6d6068e32 (diff)
downloadydb-4d8b546b89b5afc08cf3667e176271c7ba935f33.tar.gz
Restoring authorship annotation for <vskipin@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/messagebus/event_loop.cpp')
-rw-r--r--library/cpp/messagebus/event_loop.cpp8
1 files changed, 4 insertions, 4 deletions
diff --git a/library/cpp/messagebus/event_loop.cpp b/library/cpp/messagebus/event_loop.cpp
index 6946ccdea4..f685135bed 100644
--- a/library/cpp/messagebus/event_loop.cpp
+++ b/library/cpp/messagebus/event_loop.cpp
@@ -79,7 +79,7 @@ public:
const char* Name;
TAtomic RunningState;
- TAtomic StopSignal;
+ TAtomic StopSignal;
TSystemEvent StoppedEvent;
TData Data;
@@ -255,7 +255,7 @@ void TChannel::TImpl::CallHandler() {
TEventLoop::TImpl::TImpl(const char* name)
: Name(name)
, RunningState(EVENT_LOOP_CREATED)
- , StopSignal(0)
+ , StopSignal(0)
{
SOCKET wakeupSockets[2];
@@ -284,7 +284,7 @@ void TEventLoop::TImpl::Run() {
SetCurrentThreadName(Name);
}
- while (AtomicGet(StopSignal) == 0) {
+ while (AtomicGet(StopSignal) == 0) {
void* cookies[1024];
const size_t count = Poller.WaitI(cookies, Y_ARRAY_SIZE(cookies));
@@ -328,7 +328,7 @@ void TEventLoop::TImpl::Run() {
}
void TEventLoop::TImpl::Stop() {
- AtomicSet(StopSignal, 1);
+ AtomicSet(StopSignal, 1);
if (AtomicGet(RunningState) == EVENT_LOOP_RUNNING) {
Wakeup();