[ignite-3] branch main updated: IGNITE-17938 Thread-safe enlisting of a primary node into a transaction implemented (#1409)

[sanpwc]

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

sanpwc 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 386a774ee0 IGNITE-17938 Thread-safe enlisting of a primary node into a 
transaction implemented (#1409)
386a774ee0 is described below

commit 386a774ee0a7406762d835dde635d71169b78074
Author: Alexander Lapin <lapin1...@gmail.com>
AuthorDate: Tue Dec 6 16:01:48 2022 +0300

    IGNITE-17938 Thread-safe enlisting of a primary node into a transaction 
implemented (#1409)
---
 .../org/apache/ignite/internal/tx/impl/ReadWriteTransactionImpl.java  | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git 
a/modules/transactions/src/main/java/org/apache/ignite/internal/tx/impl/ReadWriteTransactionImpl.java
 
b/modules/transactions/src/main/java/org/apache/ignite/internal/tx/impl/ReadWriteTransactionImpl.java
index c7652adb88..32d10ee997 100644
--- 
a/modules/transactions/src/main/java/org/apache/ignite/internal/tx/impl/ReadWriteTransactionImpl.java
+++ 
b/modules/transactions/src/main/java/org/apache/ignite/internal/tx/impl/ReadWriteTransactionImpl.java
@@ -82,9 +82,7 @@ public class ReadWriteTransactionImpl extends 
IgniteAbstractTransactionImpl {
     /** {@inheritDoc} */
     @Override
     public IgniteBiTuple<ClusterNode, Long> enlist(ReplicationGroupId 
replicationGroupId, IgniteBiTuple<ClusterNode, Long> nodeAndTerm) {
-        enlisted.put(replicationGroupId, nodeAndTerm);
-
-        return nodeAndTerm;
+        return enlisted.computeIfAbsent(replicationGroupId, k -> nodeAndTerm);
     }
 
     /** {@inheritDoc} */