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 | 48ea53d4c114c948fa16fee5ec66de2552c93471 (patch) | |
tree | d443cad34860b58886dc7725a27c7fe0c9b5fe13 /library/cpp/messagebus/rain_check/http/client.cpp | |
parent | 30f4921b0fa8722e5531e72cb40a93b526f6973a (diff) | |
download | ydb-48ea53d4c114c948fa16fee5ec66de2552c93471.tar.gz |
Restoring authorship annotation for <luckygeck@yandex-team.ru>. Commit 1 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 5ef5ceeece..0d2d717cc8 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(); - } + } -} +} |