AGentooCat/i2p.i2p
1
0
Fork 0
forked from I2P_Developers/i2p.i2p
Code Issues Pull Requests Packages Projects Releases Wiki Activity

NDT: Thread tweaks

Browse Source
This commit is contained in:
zzz
2018-11-16 19:43:11 +00:00
parent c07f68e622
commit bfb6eba90c
1 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
apps/routerconsole/java/src/edu/internet2/ndt/Tcpbw100.java
View File

@@ -119,6 +119,7 @@ import com.vuze.plugins.mlab.tools.ndt.swingemu.*;
import net.i2p.I2PAppContext; import net.i2p.I2PAppContext;
import net.i2p.util.Addresses; import net.i2p.util.Addresses;
import net.i2p.util.I2PAppThread;
import net.i2p.util.Log; import net.i2p.util.Log;
/* /*
@@ -1132,7 +1133,7 @@ public class Tcpbw100 extends JApplet implements ActionListener {
*/ */
synchronized public void runtest() { synchronized public void runtest() {
pub_status = "notStarted"; 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 // Listen for server sending out a test for the S->C direction , and
// update test results // update test results
OsfwWorker osfwTest = new OsfwWorker(srvSocket, iTestTime, this); 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 // Now, run Test from client for the C->S direction SFW test
// trying to connect to ephemeral port number sent by server // trying to connect to ephemeral port number sent by server
@@ -1887,7 +1888,7 @@ public class Tcpbw100 extends JApplet implements ActionListener {
pub_time = _dTime; pub_time = _dTime;
// sleep for 10 s // sleep for 10 s
new Thread() { new I2PAppThread("NDT Sleeper") {
public void run() { public void run() {
try { try {
@@ -4510,7 +4511,7 @@ public class Tcpbw100 extends JApplet implements ActionListener {
thread_group.setDaemon( true ); thread_group.setDaemon( true );
Thread t = Thread t =
new Thread( new I2PAppThread(
thread_group, thread_group,
new Runnable() new Runnable()
{ {
@@ -4529,7 +4530,8 @@ public class Tcpbw100 extends JApplet implements ActionListener {
//sem.release(); //sem.release();
} }
} }
}); },
"TestWorker");
t.setDaemon( true ); t.setDaemon( true );
t.start(); t.start();