diff options
author | hiddenpath <hiddenpath@yandex-team.com> | 2024-12-24 20:33:51 +0300 |
---|---|---|
committer | hiddenpath <hiddenpath@yandex-team.com> | 2024-12-24 21:37:04 +0300 |
commit | 5316c104d58281584317972b3b4a1fc19dbbef45 (patch) | |
tree | 31e76ce65193995b23a380fcc9dd94bfcf11b4ad /yt/cpp/mapreduce/client/retry_heavy_write_request.cpp | |
parent | 4aba061d7839ceee149b6dcf222aa348bf430c44 (diff) | |
download | ydb-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.cpp | 6 |
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([] { }); |