diff options
author | luckygeck <luckygeck@yandex-team.ru> | 2022-02-10 16:49:18 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:49:18 +0300 |
commit | cb691264f012c552bac85a9fe352baa062cd81dd (patch) | |
tree | 5d5cb817648f650d76cf1076100726fd9b8448e8 /library/cpp/messagebus/rain_check/http/client.cpp | |
parent | 48ea53d4c114c948fa16fee5ec66de2552c93471 (diff) | |
download | ydb-cb691264f012c552bac85a9fe352baa062cd81dd.tar.gz |
Restoring authorship annotation for <luckygeck@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/messagebus/rain_check/http/client.cpp')
-rw-r--r-- | library/cpp/messagebus/rain_check/http/client.cpp | 22 |
1 files changed, 11 insertions, 11 deletions
diff --git a/library/cpp/messagebus/rain_check/http/client.cpp b/library/cpp/messagebus/rain_check/http/client.cpp index 0d2d717cc8..5ef5ceeece 100644 --- a/library/cpp/messagebus/rain_check/http/client.cpp +++ b/library/cpp/messagebus/rain_check/http/client.cpp @@ -10,8 +10,8 @@ #include <util/generic/ptr.h> #include <util/generic/strbuf.h> -#include <util/network/socket.h> -#include <util/stream/str.h> +#include <util/network/socket.h> +#include <util/stream/str.h> namespace NRainCheck { class THttpCallback: public NNeh::IOnRecv { @@ -66,11 +66,11 @@ namespace NRainCheck { void THttpClientService::SendPost(TString addr, const TString& data, const THttpHeaders& headers, THttpFuture* future) { Y_VERIFY(!!future, "future is NULL."); - + TTaskRunnerBase* current = TTaskRunnerBase::CurrentTask(); future->SetRunning(current); future->Task = current; - + THolder<THttpCallback> callback(new THttpCallback(future)); NNeh::TServiceStatRef stat; try { @@ -93,7 +93,7 @@ namespace NRainCheck { TTaskRunnerBase* current = TTaskRunnerBase::CurrentTask(); future->SetRunning(current); future->Task = current; - + THolder<THttpCallback> callback(new THttpCallback(future)); NNeh::TServiceStatRef stat; try { @@ -107,11 +107,11 @@ namespace NRainCheck { future->SetFail(THttpFuture::OtherError, err.AsStrBuf()); } } - + bool THttpFuture::HasHttpCode() const { return !!HttpCode; - } - + } + bool THttpFuture::HasResponseBody() const { return !!Response; } @@ -121,7 +121,7 @@ namespace NRainCheck { Y_ASSERT(HasHttpCode()); return static_cast<ui32>(*HttpCode); - } + } TString THttpFuture::GetResponseBody() const { Y_ASSERT(IsDone()); @@ -149,6 +149,6 @@ namespace NRainCheck { ErrorDescription = errorDescription; Response.Destroy(); SetDone(); - } + } -} +} |