(ignite-3) branch main updated: IGNITE-28361 Fix a race between TX cleanup and resource vacuum (#7870)

[ibessonov]

This is an automated email from the ASF dual-hosted git repository.

ibessonov pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git


The following commit(s) were added to refs/heads/main by this push:
     new 8f030445ed8 IGNITE-28361 Fix a race between TX cleanup and resource 
vacuum (#7870)
8f030445ed8 is described below

commit 8f030445ed8838df40786a48d42503bfa51c422c
Author: Ivan Bessonov <bessonov...@gmail.com>
AuthorDate: Fri Mar 27 09:37:13 2026 +0300

    IGNITE-28361 Fix a race between TX cleanup and resource vacuum (#7870)
    
    Signed-off-by: ibessonov <bessonov...@gmail.com>
---
 .../ignite/internal/tx/impl/RemotelyTriggeredResourceRegistry.java   | 5 +++++
 1 file changed, 5 insertions(+)

diff --git 
a/modules/transactions/src/main/java/org/apache/ignite/internal/tx/impl/RemotelyTriggeredResourceRegistry.java
 
b/modules/transactions/src/main/java/org/apache/ignite/internal/tx/impl/RemotelyTriggeredResourceRegistry.java
index 823434b3741..b7d8064fbc1 100644
--- 
a/modules/transactions/src/main/java/org/apache/ignite/internal/tx/impl/RemotelyTriggeredResourceRegistry.java
+++ 
b/modules/transactions/src/main/java/org/apache/ignite/internal/tx/impl/RemotelyTriggeredResourceRegistry.java
@@ -148,6 +148,11 @@ public class RemotelyTriggeredResourceRegistry {
     public void closeByRemoteHostId(UUID remoteHostId) {
         Set<FullyQualifiedResourceId> resourceIds = 
remoteHostsToResources.get(remoteHostId);
 
+        if (resourceIds == null) {
+            // Remote host resources were already closed, likely by a 
concurrent call of "removeRemoteHostResource" method.
+            return;
+        }
+
         for (FullyQualifiedResourceId resourceId : resourceIds) {
             try {
                 close(resourceId);