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/09/16 13:36:38 UTC
ignite git commit: ignite-comm-opts
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 <sb...@gridgain.com>
Authored: Fri Sep 16 16:36:32 2016 +0300
Committer: sboikov <sb...@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} */