You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2016/06/17 11:28:44 UTC
[2/2] ignite git commit: ignite-3212 Remove transaction from map if
IgniteTxManager.onStarted fails.
ignite-3212 Remove transaction from map if IgniteTxManager.onStarted fails.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/29a8eaf3
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/29a8eaf3
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/29a8eaf3
Branch: refs/heads/ignite-3211
Commit: 29a8eaf3ab53694a4fb68d12adaa2100267bd80d
Parents: 0fd1ab6
Author: sboikov <sb...@gridgain.com>
Authored: Fri Jun 17 14:25:17 2016 +0300
Committer: sboikov <sb...@gridgain.com>
Committed: Fri Jun 17 14:25:17 2016 +0300
----------------------------------------------------------------------
.../internal/processors/cache/transactions/IgniteTxManager.java | 4 ++++
1 file changed, 4 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/29a8eaf3/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxManager.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxManager.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxManager.java
index 4ec280f..a30718c 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxManager.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxManager.java
@@ -568,6 +568,10 @@ public class IgniteTxManager extends GridCacheSharedManagerAdapter {
", tx=" + tx + ']';
if (isCompleted(tx)) {
+ ConcurrentMap<GridCacheVersion, IgniteInternalTx> txIdMap = transactionMap(tx);
+
+ txIdMap.remove(tx.xidVersion(), tx);
+
if (log.isDebugEnabled())
log.debug("Attempt to start a completed transaction (will ignore): " + tx);