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 2015/05/15 16:02:41 UTC
[39/47] incubator-ignite git commit: IGNITE-709 Rename
brokeConnection() to brakeConnection().
IGNITE-709 Rename brokeConnection() to brakeConnection().
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/4fd4c24d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/4fd4c24d
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/4fd4c24d
Branch: refs/heads/ignite-709_3
Commit: 4fd4c24da1412b24d67271ea7307b7a3b66f2875
Parents: 2109bc0
Author: sevdokimov <se...@gridgain.com>
Authored: Fri May 15 14:34:37 2015 +0300
Committer: sevdokimov <se...@gridgain.com>
Committed: Fri May 15 14:34:37 2015 +0300
----------------------------------------------------------------------
.../apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpi.java | 2 +-
.../ignite/spi/discovery/tcp/TcpClientDiscoverySpiSelfTest.java | 4 ++--
2 files changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4fd4c24d/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpi.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpi.java b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpi.java
index 316afec..f4e1430 100644
--- a/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpi.java
+++ b/modules/core/src/main/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpi.java
@@ -665,7 +665,7 @@ public class TcpClientDiscoverySpi extends TcpDiscoverySpiAdapter implements Tcp
/**
* FOR TEST PURPOSE ONLY!
*/
- public void brokeConnection() {
+ public void brakeConnection() {
U.closeQuiet(msgWorker.currSock);
}
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/4fd4c24d/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpiSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpiSelfTest.java b/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpiSelfTest.java
index 64e4488..87b63c4 100644
--- a/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpiSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/spi/discovery/tcp/TcpClientDiscoverySpiSelfTest.java
@@ -448,7 +448,7 @@ public class TcpClientDiscoverySpiSelfTest extends GridCommonAbstractTest {
attachListeners(2, 3);
- ((TcpClientDiscoverySpi)G.ignite("client-2").configuration().getDiscoverySpi()).brokeConnection();
+ ((TcpClientDiscoverySpi)G.ignite("client-2").configuration().getDiscoverySpi()).brakeConnection();
G.ignite("client-2").message().remoteListen(null, new MessageListener()); // Send some discovery message.
@@ -1114,7 +1114,7 @@ public class TcpClientDiscoverySpiSelfTest extends GridCommonAbstractTest {
public void pauseAll() {
pauseResumeOperation(true, openSockLock, writeLock);
- brokeConnection();
+ brakeConnection();
}
/**