Test arbiters using YQL transactions with a pipe cache bugfix

ydb-platform · May 15, 2024 · b701f86 · b701f86
1 parent 18ea57a
commit b701f86
Show file tree

Hide file tree

Showing 3 changed files with 494 additions and 2 deletions.
diff --git a/ydb/core/tablet/tablet_pipe_client_cache.cpp b/ydb/core/tablet/tablet_pipe_client_cache.cpp
@@ -183,13 +183,17 @@ namespace NTabletPipe {
         }
 
     private:
-        void MoveToPool(ui64 tabletId, const TClientCacheEntry& currentClient) {
+        void MoveToPool(ui64 tabletId, TClientCacheEntry& currentClient) {
             TClientCacheEntry* insertedClient;
             if (!PoolContainer->Insert(tabletId, currentClient, insertedClient)) {
                 Y_DEBUG_ABORT_UNLESS(!insertedClient->Client);
                 *insertedClient = currentClient;
             }
 
+            // Note: client was moved to pool, make sure it's not closed by
+            // the eviction callback
+            currentClient.Client = {};
+
             Container->Erase(tabletId);
         }
 

diff --git a/ydb/core/tx/datashard/datashard_outreadset.cpp b/ydb/core/tx/datashard/datashard_outreadset.cpp
@@ -178,7 +178,7 @@ void TOutReadSets::ResendAll(const TActorContext& ctx) {
         }
         ui64 seqNo = rs.first;
         ui64 target = rs.second.To;
-        Self->ResendReadSetQueue.Progress(rs.first, ctx);
+        Self->ResendReadSetQueue.Progress(seqNo, ctx);
         pendingPipeTrackerCommands.AttachTablet(seqNo, target);
     }
     pendingPipeTrackerCommands.Apply(Self->ResendReadSetPipeTracker, ctx);