diff options
author | aozeritsky <aozeritsky@yandex-team.ru> | 2022-04-26 16:45:00 +0300 |
---|---|---|
committer | aozeritsky <aozeritsky@yandex-team.ru> | 2022-04-26 16:45:00 +0300 |
commit | 28c687b211b341db3f656a7244dbd70e591dd979 (patch) | |
tree | d4e98c345c61e5121d7556cc5f4565475623f3f8 | |
parent | 15d9d7bab98163c05dd58994f66d5e551119db0b (diff) | |
download | ydb-28c687b211b341db3f656a7244dbd70e591dd979.tar.gz |
YQL-14753: Add timeout to solomon request
ref:e052e7ba3382fdcf3c024bee9f45b9a0e5189853
-rw-r--r-- | ydb/library/yql/utils/actors/http_sender_actor.cpp | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/ydb/library/yql/utils/actors/http_sender_actor.cpp b/ydb/library/yql/utils/actors/http_sender_actor.cpp index 3cb61468c81..8423d922727 100644 --- a/ydb/library/yql/utils/actors/http_sender_actor.cpp +++ b/ydb/library/yql/utils/actors/http_sender_actor.cpp @@ -38,8 +38,9 @@ private: void Handle(NHttp::TEvHttpProxy::TEvHttpOutgoingRequest::TPtr& ev) { Request = ev->Get()->Request; + Timeout = ev->Get()->Timeout; Cookie = ev->Cookie; - Send(HttpProxyId, new NHttp::TEvHttpProxy::TEvHttpOutgoingRequest(Request->Duplicate())); + Send(HttpProxyId, new NHttp::TEvHttpProxy::TEvHttpOutgoingRequest(Request->Duplicate(), Timeout)); } void Handle(NHttp::TEvHttpProxy::TEvHttpIncomingResponse::TPtr& ev) { @@ -54,7 +55,7 @@ private: return; } - Schedule(GetRetryDelay(), new NHttp::TEvHttpProxy::TEvHttpOutgoingRequest(Request->Duplicate())); + Schedule(GetRetryDelay(), new NHttp::TEvHttpProxy::TEvHttpOutgoingRequest(Request->Duplicate(), Timeout)); } void Handle(TEvents::TEvPoison::TPtr&) { @@ -75,6 +76,7 @@ private: ui32 RetryCount = 0; TDuration CurrentDelay = BaseRetryDelay; NHttp::THttpOutgoingRequestPtr Request; + TDuration Timeout; ui64 Cookie = 0; }; |