aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authoraozeritsky <aozeritsky@yandex-team.ru>2022-04-26 16:45:00 +0300
committeraozeritsky <aozeritsky@yandex-team.ru>2022-04-26 16:45:00 +0300
commit28c687b211b341db3f656a7244dbd70e591dd979 (patch)
treed4e98c345c61e5121d7556cc5f4565475623f3f8
parent15d9d7bab98163c05dd58994f66d5e551119db0b (diff)
downloadydb-28c687b211b341db3f656a7244dbd70e591dd979.tar.gz
YQL-14753: Add timeout to solomon request
ref:e052e7ba3382fdcf3c024bee9f45b9a0e5189853
-rw-r--r--ydb/library/yql/utils/actors/http_sender_actor.cpp6
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;
};