You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by vo...@apache.org on 2016/01/02 10:21:41 UTC
[02/13] ignite git commit: IGNITE-2263: retain -> viewReadOnly in
GridIoManager.
IGNITE-2263: retain -> viewReadOnly in GridIoManager.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/658c3eba
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/658c3eba
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/658c3eba
Branch: refs/heads/ignite-2263
Commit: 658c3ebafa333e74c8441d3986fd07460b34c40d
Parents: 46f5435
Author: thatcoach <pp...@list.ru>
Authored: Sat Jan 2 11:41:22 2016 +0300
Committer: thatcoach <pp...@list.ru>
Committed: Sat Jan 2 11:41:22 2016 +0300
----------------------------------------------------------------------
.../ignite/internal/managers/communication/GridIoManager.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/658c3eba/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java
index 4fd0b67..52c64d1 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/managers/communication/GridIoManager.java
@@ -1549,9 +1549,11 @@ public class GridIoManager extends GridManagerAdapter<CommunicationSpi<Serializa
}
}
catch (IgniteSpiException e) {
+
+
throw new IgniteCheckedException("Failed to send message (nodes may have left the grid or " +
"TCP connection cannot be established due to firewall issues) " +
- "[nodes=" + F.retain(nodes, true, pred) + ", topic=" + topic +
+ "[nodes=" + F.viewReadOnly(nodes, F.<ClusterNode>identity(), pred) + ", topic=" + topic +
", msg=" + msg + ", policy=" + plc + ']', e);
}
}