Repository: ignite Updated Branches: refs/heads/ignite-comm-opts-2conn c9f62b815 -> 522a65dcd
ignite-comm-opts Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/522a65dc Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/522a65dc Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/522a65dc Branch: refs/heads/ignite-comm-opts-2conn Commit: 522a65dcd6f8915a23156703d07baab97d27b762 Parents: c9f62b8 Author: sboikov <sboi...@gridgain.com> Authored: Fri Sep 16 16:36:32 2016 +0300 Committer: sboikov <sboi...@gridgain.com> Committed: Fri Sep 16 16:36:32 2016 +0300 ---------------------------------------------------------------------- .../managers/communication/GridIoManager.java | 40 ++++++++++---------- 1 file changed, 20 insertions(+), 20 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/522a65dc/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 f869c5a..9e547ca 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 @@ -529,26 +529,26 @@ public class GridIoManager extends GridManagerAdapter<CommunicationSpi<Serializa } } -// Thread t = new Thread( -// new Runnable() { -// @Override public void run() { -// for (;;) { -// try { -// Thread.sleep(5000); -// } -// catch (InterruptedException e) { -// e.printStackTrace(); -// } -// -// dumpStats(); -// } -// } -// } -// ); -// -// t.setDaemon(true); -// -// t.start(); + Thread t = new Thread( + new Runnable() { + @Override public void run() { + for (;;) { + try { + Thread.sleep(5000); + } + catch (InterruptedException e) { + e.printStackTrace(); + } + + dumpStats(); + } + } + } + ); + + t.setDaemon(true); + + t.start(); } /** {@inheritDoc} */
