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

synchronized on (and .wait/notify against) the ShellCommand, not the Thread.

Browse Source 
in general the old way worked often, but would sometimes cause a race, this should be a bit safer
This commit is contained in:
jrandom
2004-09-01 23:08:35 +00:00
committed by zzz
parent 79e973af65
commit 8aa07e6f12
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
core/java/src/net/i2p/util/ShellCommand.java
View File

@ -48,11 +48,11 @@ public class ShellCommand {
*/
private class CommandThread extends Thread {
Thread caller;
Object caller;
boolean consumeOutput;
String shellCommand;
CommandThread(Thread caller, String shellCommand, boolean consumeOutput) {
CommandThread(Object caller, String shellCommand, boolean consumeOutput) {
super("CommandThread");
this.caller = caller;
this.shellCommand = shellCommand;
@ -63,7 +63,7 @@ public class ShellCommand {
_commandSuccessful = execute(shellCommand, consumeOutput, WAIT_FOR_EXIT_STATUS);
if (_isTimerRunning) {
synchronized(caller) {
caller.interrupt(); // In case the caller is still in the wait() state.
caller.notifyAll(); // In case the caller is still in the wait() state.
}
}
}
@ -236,7 +236,7 @@ public class ShellCommand {
*/
public synchronized boolean executeAndWaitTimed(String shellCommand, int seconds) {
_commandThread = new CommandThread(Thread.currentThread(), shellCommand, NO_CONSUME_OUTPUT);
_commandThread = new CommandThread(this, shellCommand, NO_CONSUME_OUTPUT);
_commandThread.start();
try {
@ -305,7 +305,7 @@ public class ShellCommand {
*/
public synchronized boolean executeSilentAndWaitTimed(String shellCommand, int seconds) {
_commandThread = new CommandThread(Thread.currentThread(), shellCommand, CONSUME_OUTPUT);
_commandThread = new CommandThread(this, shellCommand, CONSUME_OUTPUT);
_commandThread.start();
try {