mirrors/cdt
1
0
Fork 0
mirror of https://github.com/eclipse-cdt/cdt synced 2025-09-10 03:53:21 +02:00
Code Issues Wiki Activity

Send a synchronization notify immediately for commands

Browse source 
wit no tokens.
This commit is contained in:
Alain Magloire 2002-09-07 14:49:09 +00:00
parent 42e4cbf928
commit 5c8cdfbd11
1 changed files with 7 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
debug/org.eclipse.cdt.debug.mi.core/src/org/eclipse/cdt/debug/mi/core/TxThread.java
View file

@ -29,7 +29,8 @@ public class TxThread extends Thread {
public void run () { public void run () {
try { try {
// signal by the session of time to die. // signal by the session of time to die.
while (session.getChannelOutputStream() != null) { OutputStream out;
while ((out = session.getChannelOutputStream()) != null) {
Command cmd = null; Command cmd = null;
CommandQueue txQueue = session.getTxQueue(); CommandQueue txQueue = session.getTxQueue();
// removeCommand() will block until a command is available. // removeCommand() will block until a command is available.
@ -48,10 +49,14 @@ public class TxThread extends Thread {
if (cmd.getToken() > 0) { if (cmd.getToken() > 0) {
CommandQueue rxQueue = session.getRxQueue(); CommandQueue rxQueue = session.getRxQueue();
rxQueue.addCommand(cmd); rxQueue.addCommand(cmd);
} else {
synchronized (cmd) {
cmd.notifyAll();
}
} }
// shove in the pipe // shove in the pipe
String str = cmd.toString(); String str = cmd.toString();
OutputStream out = session.getChannelOutputStream();
if (out != null) { if (out != null) {
out.write(str.getBytes()); out.write(str.getBytes());
out.flush(); out.flush();