aboutsummaryrefslogtreecommitdiffstats
path: root/yt/cpp/mapreduce/client/retry_heavy_write_request.cpp
diff options
context:
space:
mode:
authorhiddenpath <hiddenpath@yandex-team.com>2024-12-24 20:33:51 +0300
committerhiddenpath <hiddenpath@yandex-team.com>2024-12-24 21:37:04 +0300
commit5316c104d58281584317972b3b4a1fc19dbbef45 (patch)
tree31e76ce65193995b23a380fcc9dd94bfcf11b4ad /yt/cpp/mapreduce/client/retry_heavy_write_request.cpp
parent4aba061d7839ceee149b6dcf222aa348bf430c44 (diff)
downloadydb-5316c104d58281584317972b3b4a1fc19dbbef45.tar.gz
Migrate THolder to std::unique_ptr in yt/cpp/mapreduce internals
commit_hash:99bfa41ffc42ed3622660b15d7ce68802e53f902
Diffstat (limited to 'yt/cpp/mapreduce/client/retry_heavy_write_request.cpp')
-rw-r--r--yt/cpp/mapreduce/client/retry_heavy_write_request.cpp6
1 files changed, 3 insertions, 3 deletions
diff --git a/yt/cpp/mapreduce/client/retry_heavy_write_request.cpp b/yt/cpp/mapreduce/client/retry_heavy_write_request.cpp
index 44c7db3a97..80f54d2340 100644
--- a/yt/cpp/mapreduce/client/retry_heavy_write_request.cpp
+++ b/yt/cpp/mapreduce/client/retry_heavy_write_request.cpp
@@ -31,7 +31,7 @@ void RetryHeavyWriteRequest(
const TClientContext& context,
const TTransactionId& parentId,
THttpHeader& header,
- std::function<THolder<IInputStream>()> streamMaker)
+ std::function<std::unique_ptr<IInputStream>()> streamMaker)
{
int retryCount = context.Config->RetryCount;
if (context.ServiceTicketAuth) {
@@ -63,7 +63,7 @@ void RetryHeavyWriteRequest(
GetFullUrlForProxy(hostName, context, header),
requestId,
header);
- TransferData(input.Get(), request->GetStream());
+ TransferData(input.get(), request->GetStream());
request->Finish()->GetResponse();
} catch (TErrorResponse& e) {
YT_LOG_ERROR("RSP %v - attempt %v failed",
@@ -100,7 +100,7 @@ THeavyRequestRetrier::THeavyRequestRetrier(TParameters parameters)
: Parameters_(std::move(parameters))
, RequestRetryPolicy_(Parameters_.ClientRetryPolicy->CreatePolicyForGenericRequest())
, StreamFactory_([] {
- return MakeHolder<TNullInput>();
+ return std::make_unique<TNullInput>();
})
{
Retry([] { });