IGNITE-3874 sync putIfAbsent forever blocked on all nodes after one node is 
stopped


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/40f64725
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/40f64725
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/40f64725

Branch: refs/heads/master
Commit: 40f647258a10fa8b42ac6fda67d6fa4db71b8100
Parents: 29f508b
Author: Anton Vinogradov <[email protected]>
Authored: Thu Sep 8 18:58:31 2016 +0300
Committer: Anton Vinogradov <[email protected]>
Committed: Fri Sep 23 11:31:17 2016 +0300

----------------------------------------------------------------------
 .../internal/processors/cache/transactions/IgniteTxManager.java | 5 +----
 1 file changed, 1 insertion(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/40f64725/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 a1580a5..c72d7f7 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
@@ -374,7 +374,7 @@ public class IgniteTxManager extends 
GridCacheSharedManagerAdapter {
                         "crashed or left grid: " + CU.txString(tx));
                 }
             }
-            catch (IgniteTxOptimisticCheckedException ignore) {
+            catch (IgniteCheckedException ignore) {
                 if (log.isDebugEnabled())
                     log.debug("Optimistic failure while invalidating 
transaction (will rollback): " +
                         tx.xidVersion());
@@ -386,9 +386,6 @@ public class IgniteTxManager extends 
GridCacheSharedManagerAdapter {
                     U.error(log, "Failed to rollback transaction: " + 
tx.xidVersion(), e);
                 }
             }
-            catch (IgniteCheckedException e) {
-                U.error(log, "Failed to invalidate transaction: " + tx, e);
-            }
         }
         else if (state == MARKED_ROLLBACK) {
             try {

Reply via email to