From bfb6eba90c742f3e9077f6e79f90ff3ea1abd29c Mon Sep 17 00:00:00 2001
From: zzz <zzz@mail.i2p>
Date: Fri, 16 Nov 2018 19:43:11 +0000
Subject: [PATCH] NDT: Thread tweaks
---
.../java/src/edu/internet2/ndt/Tcpbw100.java | 12 +++++++-----
1 file changed, 7 insertions(+), 5 deletions(-)
diff --git a/apps/routerconsole/java/src/edu/internet2/ndt/Tcpbw100.java b/apps/routerconsole/java/src/edu/internet2/ndt/Tcpbw100.java
index e7a6c8aea7..0a871ffca4 100644
--- a/apps/routerconsole/java/src/edu/internet2/ndt/Tcpbw100.java
+++ b/apps/routerconsole/java/src/edu/internet2/ndt/Tcpbw100.java
@@ -119,6 +119,7 @@ import com.vuze.plugins.mlab.tools.ndt.swingemu.*;
import net.i2p.I2PAppContext;
import net.i2p.util.Addresses;
+import net.i2p.util.I2PAppThread;
import net.i2p.util.Log;
/*
@@ -1132,7 +1133,7 @@ public class Tcpbw100 extends JApplet implements ActionListener {
*/
synchronized public void runtest() {
pub_status = "notStarted";
- new Thread(new TestWorker()).start();
+ new I2PAppThread(new TestWorker(), "TestWorker").start();
}
/**
@@ -1684,7 +1685,7 @@ public class Tcpbw100 extends JApplet implements ActionListener {
// Listen for server sending out a test for the S->C direction , and
// update test results
OsfwWorker osfwTest = new OsfwWorker(srvSocket, iTestTime, this);
- new Thread(osfwTest).start();
+ new I2PAppThread(osfwTest, "OsfwWorker").start();
// Now, run Test from client for the C->S direction SFW test
// trying to connect to ephemeral port number sent by server
@@ -1887,7 +1888,7 @@ public class Tcpbw100 extends JApplet implements ActionListener {
pub_time = _dTime;
// sleep for 10 s
- new Thread() {
+ new I2PAppThread("NDT Sleeper") {
public void run() {
try {
@@ -4510,7 +4511,7 @@ public class Tcpbw100 extends JApplet implements ActionListener {
thread_group.setDaemon( true );
Thread t =
- new Thread(
+ new I2PAppThread(
thread_group,
new Runnable()
{
@@ -4529,7 +4530,8 @@ public class Tcpbw100 extends JApplet implements ActionListener {
//sem.release();
}
}
- });
+ },
+ "TestWorker");
t.setDaemon( true );
t.start();
--
GitLab