[C++ SDK] Fixed bug in TQueryClient::Commit (#18701)

Author: Gazizonoki

src/client/query/client.cpp

@@ -752,9 +752,11 @@ class TTransaction::TImpl : public std::enable_shared_from_this<TImpl> {
     }
 
     TAsyncStatus Precommit() const {
+        auto self = shared_from_this();
+
         TStatus status(EStatus::SUCCESS, {});
 
-        for (auto& callback : PrecommitCallbacks) {
+        for (auto& callback : self->PrecommitCallbacks) {
             if (!callback) {
                 continue;
             }
@@ -775,7 +777,9 @@ class TTransaction::TImpl : public std::enable_shared_from_this<TImpl> {
     }
 
     NThreading::TFuture<void> ProcessFailure() const {
-        for (auto& callback : OnFailureCallbacks) {
+        auto self = shared_from_this();
+
+        for (auto& callback : self->OnFailureCallbacks) {
             if (!callback) {
                 continue;
             }
@@ -803,7 +807,7 @@ class TTransaction::TImpl : public std::enable_shared_from_this<TImpl> {
             co_return TCommitTransactionResult(TStatus(precommitResult));
         }
 
-        PrecommitCallbacks.clear();
+        self->PrecommitCallbacks.clear();
 
         auto commitResult = co_await self->Session_.Client_->CommitTransaction(self->TxId_, settingsCopy, self->Session_);
 

src/client/table/impl/transaction.cpp

@@ -11,9 +11,11 @@ TTransaction::TImpl::TImpl(const TSession& session, const std::string& txId)
 
 TAsyncStatus TTransaction::TImpl::Precommit() const
 {
+    auto self = shared_from_this();
+
     TStatus status(EStatus::SUCCESS, {});
 
-    for (auto& callback : PrecommitCallbacks) {
+    for (auto& callback : self->PrecommitCallbacks) {
         if (!callback) {
             continue;
         }
@@ -35,7 +37,9 @@ TAsyncStatus TTransaction::TImpl::Precommit() const
 
 NThreading::TFuture<void> TTransaction::TImpl::ProcessFailure() const
 {
-    for (auto& callback : OnFailureCallbacks) {
+    auto self = shared_from_this();
+
+    for (auto& callback : self->OnFailureCallbacks) {
         if (!callback) {
             continue;
         }