diff options
| author | a-romanov <a-romanov@yandex-team.ru> | 2022-02-10 16:48:11 +0300 |
|---|---|---|
| committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:48:11 +0300 |
| commit | 0f4c5d1e8c0672bf0a1f2f2d8acac5ba24772435 (patch) | |
| tree | b222e5ac2e2e98872661c51ccceee5da0d291e13 /library/cpp/messagebus/session_impl.cpp | |
| parent | aa2986a34bde73b2cdcea5080c4443b7cf2ba686 (diff) | |
| download | ydb-0f4c5d1e8c0672bf0a1f2f2d8acac5ba24772435.tar.gz | |
Restoring authorship annotation for <a-romanov@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/messagebus/session_impl.cpp')
| -rw-r--r-- | library/cpp/messagebus/session_impl.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/library/cpp/messagebus/session_impl.cpp b/library/cpp/messagebus/session_impl.cpp index 7b2e4f519e..ddf9f360c4 100644 --- a/library/cpp/messagebus/session_impl.cpp +++ b/library/cpp/messagebus/session_impl.cpp @@ -110,7 +110,7 @@ TBusSessionImpl::TBusSessionImpl(bool isSource, TBusMessageQueue* queue, TBusPro { Impl->DeadAcceptorStatusSummary.Summary = true; - ReadEventLoopThread.Reset(new NThreading::TLegacyFuture<void, false>(std::bind(&TEventLoop::Run, std::ref(ReadEventLoop)))); + ReadEventLoopThread.Reset(new NThreading::TLegacyFuture<void, false>(std::bind(&TEventLoop::Run, std::ref(ReadEventLoop)))); WriteEventLoopThread.Reset(new NThreading::TLegacyFuture<void, false>(std::bind(&TEventLoop::Run, std::ref(WriteEventLoop)))); Queue->Schedule(IScheduleItemAutoPtr(new TScheduleSession(this, TInstant::Now() + Config.Secret.TimeoutPeriod))); @@ -442,7 +442,7 @@ void TBusSessionImpl::Act(TStatusTag) { EShutdownState shutdownState = StatusData.ShutdownState.State.Get(); - StatusData.ConnectionsAcceptorsSnapshotsQueue.DequeueAllLikelyEmpty(std::bind(&TBusSessionImpl::ProcessConnectionsAcceptorsShapshotQueueItem, this, std::placeholders::_1)); + StatusData.ConnectionsAcceptorsSnapshotsQueue.DequeueAllLikelyEmpty(std::bind(&TBusSessionImpl::ProcessConnectionsAcceptorsShapshotQueueItem, this, std::placeholders::_1)); GetDeadConnectionWriterStatusQueue()->DequeueAllLikelyEmpty(); GetDeadConnectionReaderStatusQueue()->DequeueAllLikelyEmpty(); |