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/28 13:07:09 UTC
[22/50] [abbrv] ignite git commit: ignite-3212 Remove tx from map if
'onStarted' failed.
ignite-3212 Remove tx from map if 'onStarted' failed.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/a70ff4c4
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/a70ff4c4
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/a70ff4c4
Branch: refs/heads/ignite-1232
Commit: a70ff4c40d9f149510b148467b1dd6ce3ad5db0d
Parents: 5e91594
Author: sboikov <sb...@gridgain.com>
Authored: Thu Jun 23 12:13:05 2016 +0300
Committer: sboikov <sb...@gridgain.com>
Committed: Thu Jun 23 12:13:05 2016 +0300
----------------------------------------------------------------------
.../internal/processors/cache/transactions/IgniteTxManager.java | 4 ++++
1 file changed, 4 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/a70ff4c4/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 e8d20b6..63c9919 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);