summaryrefslogtreecommitdiffstats
path: root/yt/cpp/mapreduce/client/transaction.cpp
diff options
context:
space:
mode:
authorhiddenpath <[email protected]>2024-12-16 18:45:28 +0300
committerhiddenpath <[email protected]>2024-12-16 19:11:27 +0300
commitdae2dbe3496d7557b1ece64d5464bd8e686995a8 (patch)
tree72899b4fb6279a620a14f71005d81afbbe93cd35 /yt/cpp/mapreduce/client/transaction.cpp
parentb1cde7dcb055fb6f3367e81fd0f57bd55b8bb93c (diff)
[yt/cpp/mapreduce] YT-23616: Move Transaction and Operation methods to THttpRawClient
commit_hash:b093be44005f3d9da9779444cbbc32b93f7372ee
Diffstat (limited to 'yt/cpp/mapreduce/client/transaction.cpp')
-rw-r--r--yt/cpp/mapreduce/client/transaction.cpp11
1 files changed, 9 insertions, 2 deletions
diff --git a/yt/cpp/mapreduce/client/transaction.cpp b/yt/cpp/mapreduce/client/transaction.cpp
index c91ac52275b..caf13194682 100644
--- a/yt/cpp/mapreduce/client/transaction.cpp
+++ b/yt/cpp/mapreduce/client/transaction.cpp
@@ -118,14 +118,21 @@ const TTransactionId TPingableTransaction::GetId() const
return TransactionId_;
}
-const std::pair<TDuration, TDuration> TPingableTransaction::GetPingInterval() const {
+const std::pair<TDuration, TDuration> TPingableTransaction::GetPingInterval() const
+{
return {MinPingInterval_, MaxPingInterval_};
}
-const TClientContext TPingableTransaction::GetContext() const {
+const TClientContext TPingableTransaction::GetContext() const
+{
return Context_;
}
+void TPingableTransaction::Ping() const
+{
+ RawClient_->PingTx(TransactionId_);
+}
+
void TPingableTransaction::Commit()
{
Stop(EStopAction::Commit);