aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus/oldmodule
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
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')
-rw-r--r--library/cpp/messagebus/oldmodule/module.cpp10
-rw-r--r--library/cpp/messagebus/oldmodule/module.h6
2 files changed, 8 insertions, 8 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());
diff --git a/library/cpp/messagebus/oldmodule/module.h b/library/cpp/messagebus/oldmodule/module.h
index 8625012e0f..8d1c4a5d52 100644
--- a/library/cpp/messagebus/oldmodule/module.h
+++ b/library/cpp/messagebus/oldmodule/module.h
@@ -127,7 +127,7 @@ namespace NBus {
}
UseAddr = !!addr;
}
-
+
public:
TString GetStatus(unsigned flags);
};
@@ -270,7 +270,7 @@ namespace NBus {
/// return human reabable status of this job
virtual TString GetStatus(unsigned flags);
-
+
/// set sleep time for job
void Sleep(int milliSeconds);
@@ -372,7 +372,7 @@ namespace NBus {
/// get status of all jobs in flight
TString GetStatus(unsigned flags = 0);
-
+
/// called when application is about to start
virtual bool StartInput();
/// called when application is about to exit