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/12/06 08:40:10 UTC
[13/50] ignite git commit: IGNITE-4304: Improved logging of deferred
TX ack message in case remote node left the grid.
IGNITE-4304: Improved logging of deferred TX ack message in case remote node left the grid.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/5b2eacfc
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/5b2eacfc
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/5b2eacfc
Branch: refs/heads/ignite-comm-balance-master
Commit: 5b2eacfc25fcffad6f438b63e08d9187635f25d3
Parents: 43ec85f
Author: devozerov <vo...@gridgain.com>
Authored: Fri Nov 25 14:09:42 2016 +0300
Committer: devozerov <vo...@gridgain.com>
Committed: Fri Nov 25 14:09:42 2016 +0300
----------------------------------------------------------------------
.../processors/cache/transactions/IgniteTxManager.java | 8 +++++---
1 file changed, 5 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/5b2eacfc/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 c72d7f7..e2e9868 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
@@ -53,7 +53,6 @@ import org.apache.ignite.internal.processors.cache.GridCacheMvccFuture;
import org.apache.ignite.internal.processors.cache.GridCacheReturnCompletableWrapper;
import org.apache.ignite.internal.processors.cache.GridCacheSharedManagerAdapter;
import org.apache.ignite.internal.processors.cache.GridDeferredAckMessageSender;
-import org.apache.ignite.internal.processors.cache.KeyCacheObject;
import org.apache.ignite.internal.processors.cache.distributed.GridCacheMappedVersion;
import org.apache.ignite.internal.processors.cache.distributed.GridCacheTxFinishSync;
import org.apache.ignite.internal.processors.cache.distributed.GridCacheTxRecoveryFuture;
@@ -282,9 +281,12 @@ public class IgniteTxManager extends GridCacheSharedManagerAdapter {
try {
cctx.io().send(nodeId, ackReq, GridIoPolicy.SYSTEM_POOL);
}
+ catch (ClusterTopologyCheckedException e) {
+ if (log.isDebugEnabled())
+ log.debug("Failed to send one phase commit ack to backup node because it left grid: " + nodeId);
+ }
catch (IgniteCheckedException e) {
- log.error("Failed to send one phase commit ack to backup node [backup=" +
- nodeId + ']', e);
+ log.error("Failed to send one phase commit ack to backup node [backup=" + nodeId + ']', e);
}
finally {
cctx.kernalContext().gateway().readUnlock();