|
@@ -111,7 +111,6 @@ public abstract class Server {
|
|
|
|
|
|
private boolean running = true; // true while server runs
|
|
private boolean running = true; // true while server runs
|
|
private LinkedList callQueue = new LinkedList(); // queued calls
|
|
private LinkedList callQueue = new LinkedList(); // queued calls
|
|
- private Object callDequeued = new Object(); // used by wait/notify
|
|
|
|
|
|
|
|
private List connectionList =
|
|
private List connectionList =
|
|
Collections.synchronizedList(new LinkedList()); //maintain a list
|
|
Collections.synchronizedList(new LinkedList()); //maintain a list
|
|
@@ -513,10 +512,6 @@ public abstract class Server {
|
|
call = (Call)callQueue.removeFirst(); // pop the queue
|
|
call = (Call)callQueue.removeFirst(); // pop the queue
|
|
}
|
|
}
|
|
|
|
|
|
- synchronized (callDequeued) { // tell others we've dequeued
|
|
|
|
- callDequeued.notify();
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
// throw the message away if it is too old
|
|
// throw the message away if it is too old
|
|
if (System.currentTimeMillis() - call.receivedTime >
|
|
if (System.currentTimeMillis() - call.receivedTime >
|
|
maxCallStartAge) {
|
|
maxCallStartAge) {
|