aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus/oldmodule/module.cpp
diff options
context:
space:
mode:
authorchernyak <chernyak@yandex-team.ru>2022-02-10 16:50:29 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:50:29 +0300
commit27d9c978ef36b8d6a70f60a38957f25d75192f70 (patch)
tree5d5cb817648f650d76cf1076100726fd9b8448e8 /library/cpp/messagebus/oldmodule/module.cpp
parentf2b67f65c49b38a882b6407926cece6fe49bd066 (diff)
downloadydb-27d9c978ef36b8d6a70f60a38957f25d75192f70.tar.gz
Restoring authorship annotation for <chernyak@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/messagebus/oldmodule/module.cpp')
-rw-r--r--library/cpp/messagebus/oldmodule/module.cpp10
1 files changed, 5 insertions, 5 deletions
diff --git a/library/cpp/messagebus/oldmodule/module.cpp b/library/cpp/messagebus/oldmodule/module.cpp
index 406724127c..24bd778799 100644
--- a/library/cpp/messagebus/oldmodule/module.cpp
+++ b/library/cpp/messagebus/oldmodule/module.cpp
@@ -402,7 +402,7 @@ namespace NBus {
DoCallReplyHandler(call);
Pending.erase(Pending.begin() + it);
}
- }
+ }
return Pending.size() > 0;
}
@@ -603,8 +603,8 @@ namespace NBus {
strReturn += call.GetStatus(flags);
}
return strReturn;
- }
-
+ }
+
TString TJobState::GetStatus(unsigned flags) {
Y_UNUSED(flags);
TString strReturn;
@@ -616,7 +616,7 @@ namespace NBus {
ToString(Status).data());
return strReturn;
}
-
+
//////////////////////////////////////////////////////////////////////
void TBusModuleImpl::CancelJob(TBusJob* job, EMessageStatus status) {
@@ -857,7 +857,7 @@ void TModuleClientHandler::OnReply(TAutoPtr<TBusMessage> req, TAutoPtr<TBusMessa
Y_ASSERT(job->Job->Message != req.Get());
job->EnqueueAndSchedule(TJobResponseMessage(req.Release(), resp.Release(), MESSAGE_OK));
job->UnRef();
-}
+}
void TModuleClientHandler::OnMessageSentOneWay(TAutoPtr<TBusMessage> req) {
TJobRunner* job = GetJob(req.Get());