aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus/oldmodule/module.cpp
diff options
context:
space:
mode:
authorsomov <somov@yandex-team.ru>2022-02-10 16:45:49 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:45:49 +0300
commit7489e4682331202b9c7d863c0898eb83d7b12c2b (patch)
tree9142afc54d335ea52910662635b898e79e192e49 /library/cpp/messagebus/oldmodule/module.cpp
parenta5950576e397b1909261050b8c7da16db58f10b1 (diff)
downloadydb-7489e4682331202b9c7d863c0898eb83d7b12c2b.tar.gz
Restoring authorship annotation for <somov@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/messagebus/oldmodule/module.cpp')
-rw-r--r--library/cpp/messagebus/oldmodule/module.cpp16
1 files changed, 8 insertions, 8 deletions
diff --git a/library/cpp/messagebus/oldmodule/module.cpp b/library/cpp/messagebus/oldmodule/module.cpp
index 8a64811979..24bd778799 100644
--- a/library/cpp/messagebus/oldmodule/module.cpp
+++ b/library/cpp/messagebus/oldmodule/module.cpp
@@ -79,19 +79,19 @@ namespace NBus {
TBusModuleImpl* const Module;
};
-
+
struct TModuleServerHandler
: public IBusServerHandler {
TModuleServerHandler(TBusModuleImpl* module)
: Module(module)
{
}
-
+
void OnMessage(TOnMessageContext& msg) override;
-
+
TBusModuleImpl* const Module;
};
-
+
struct TBusModuleImpl: public TBusModuleInternal {
TBusModule* const Module;
@@ -677,7 +677,7 @@ namespace NBus {
return true;
}
-
+
bool TBusModule::Shutdown() {
Impl->Shutdown();
@@ -702,7 +702,7 @@ TBusSession* TMyModule::CreateExtSession(TBusMessageQueue& queue) {
Impl->Queue = queue;
return true;
}
-
+
int TBusModule::GetModuleSessionInFlight() const {
return Impl->Size();
}
@@ -781,11 +781,11 @@ void TBusModuleImpl::DestroyJob(TJobRunner* job) {
if (jobCount == 0) {
ShutdownCondVar.BroadCast();
}
- }
+ }
}
job->JobStorageIterator = TList<TJobRunner*>::iterator();
-}
+}
void TBusModuleImpl::OnMessageReceived(TAutoPtr<TBusMessage> msg0, TOnMessageContext& context) {
TBusMessage* msg = !!msg0 ? msg0.Get() : context.GetMessage();