diff options
| author | chernyak <[email protected]> | 2022-02-10 16:50:29 +0300 | 
|---|---|---|
| committer | Daniil Cherednik <[email protected]> | 2022-02-10 16:50:29 +0300 | 
| commit | 27d9c978ef36b8d6a70f60a38957f25d75192f70 (patch) | |
| tree | 5d5cb817648f650d76cf1076100726fd9b8448e8 /library/cpp/messagebus/oldmodule/module.cpp | |
| parent | f2b67f65c49b38a882b6407926cece6fe49bd066 (diff) | |
Restoring authorship annotation for <[email protected]>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/messagebus/oldmodule/module.cpp')
| -rw-r--r-- | library/cpp/messagebus/oldmodule/module.cpp | 10 | 
1 files changed, 5 insertions, 5 deletions
| diff --git a/library/cpp/messagebus/oldmodule/module.cpp b/library/cpp/messagebus/oldmodule/module.cpp index 406724127cf..24bd778799f 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()); | 
