Repository: incubator-ignite Updated Branches: refs/heads/ignite-901 1b2ea262e -> 1b2e0b113
# ignite-901 Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/1b2e0b11 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/1b2e0b11 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/1b2e0b11 Branch: refs/heads/ignite-901 Commit: 1b2e0b1130b5d346122a9a66f455dcfa78fec361 Parents: 1b2ea26 Author: sboikov <sboi...@gridgain.com> Authored: Mon Jul 13 18:06:59 2015 +0300 Committer: sboikov <sboi...@gridgain.com> Committed: Mon Jul 13 18:06:59 2015 +0300 ---------------------------------------------------------------------- .../internal/util/ipc/shmem/IpcSharedMemoryClientEndpoint.java | 5 +++-- .../ignite/internal/IgniteClientReconnectAbstractTest.java | 2 ++ .../apache/ignite/internal/IgniteClientReconnectCacheTest.java | 6 +++++- 3 files changed, 10 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1b2e0b11/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryClientEndpoint.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryClientEndpoint.java b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryClientEndpoint.java index c935c4a..a4f7804 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryClientEndpoint.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/util/ipc/shmem/IpcSharedMemoryClientEndpoint.java @@ -59,8 +59,9 @@ public class IpcSharedMemoryClientEndpoint implements IpcEndpoint { * @param outSpace Out space. * @param parent Parent logger. */ - public IpcSharedMemoryClientEndpoint(IpcSharedMemorySpace inSpace, IpcSharedMemorySpace outSpace, - IgniteLogger parent) { + public IpcSharedMemoryClientEndpoint(IpcSharedMemorySpace inSpace, + IpcSharedMemorySpace outSpace, + IgniteLogger parent) { assert inSpace != null; assert outSpace != null; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1b2e0b11/modules/core/src/test/java/org/apache/ignite/internal/IgniteClientReconnectAbstractTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/IgniteClientReconnectAbstractTest.java b/modules/core/src/test/java/org/apache/ignite/internal/IgniteClientReconnectAbstractTest.java index 8199a2c..c034b12 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/IgniteClientReconnectAbstractTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/IgniteClientReconnectAbstractTest.java @@ -74,6 +74,8 @@ public abstract class IgniteClientReconnectAbstractTest extends GridCommonAbstra BlockTpcCommunicationSpi commSpi = new BlockTpcCommunicationSpi(); + commSpi.setSharedMemoryPort(-1); + cfg.setCommunicationSpi(commSpi); if (clientMode) http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/1b2e0b11/modules/core/src/test/java/org/apache/ignite/internal/IgniteClientReconnectCacheTest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/IgniteClientReconnectCacheTest.java b/modules/core/src/test/java/org/apache/ignite/internal/IgniteClientReconnectCacheTest.java index e69479b..be3234d 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/IgniteClientReconnectCacheTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/IgniteClientReconnectCacheTest.java @@ -70,7 +70,11 @@ public class IgniteClientReconnectCacheTest extends IgniteClientReconnectAbstrac @Override protected IgniteConfiguration getConfiguration(String gridName) throws Exception { IgniteConfiguration cfg = super.getConfiguration(gridName); - cfg.setCommunicationSpi(new TestCommunicationSpi()); + TestCommunicationSpi commSpi = new TestCommunicationSpi(); + + commSpi.setSharedMemoryPort(-1); + + cfg.setCommunicationSpi(commSpi); cfg.setPeerClassLoadingEnabled(false);
