diff options
author | Mark Spruiell <mes@zeroc.com> | 2002-06-28 22:27:13 +0000 |
---|---|---|
committer | Mark Spruiell <mes@zeroc.com> | 2002-06-28 22:27:13 +0000 |
commit | 8d4be6b08f718253b9ff83edf07a8c9a16f42178 (patch) | |
tree | 512293ebf4c40767f74c91cced7e84f0d5dcd1cf /java/src/IceInternal/ThreadPool.java | |
parent | removing Win32 hacks (diff) | |
download | ice-8d4be6b08f718253b9ff83edf07a8c9a16f42178.tar.bz2 ice-8d4be6b08f718253b9ff83edf07a8c9a16f42178.tar.xz ice-8d4be6b08f718253b9ff83edf07a8c9a16f42178.zip |
more Win32 hack cleanup
Diffstat (limited to 'java/src/IceInternal/ThreadPool.java')
-rw-r--r-- | java/src/IceInternal/ThreadPool.java | 31 |
1 files changed, 10 insertions, 21 deletions
diff --git a/java/src/IceInternal/ThreadPool.java b/java/src/IceInternal/ThreadPool.java index 40bd7427007..4472d02bfc1 100644 --- a/java/src/IceInternal/ThreadPool.java +++ b/java/src/IceInternal/ThreadPool.java @@ -418,27 +418,18 @@ public final class ThreadPool } } - // - // First, we call selectNonBlocking(). This is necessary to - // ensure that the selected key set is updated (i.e., new - // channels added, closed channels removed, etc.). If no keys - // are present in the key set, then we'll call select() to - // block until a new event is ready. - // - //selectNonBlocking(); - //if(_keys.size() == 0) + select(); + if(_keys.size() == 0) // Timeout. { - int ret = select(); - if(ret == 0) // Timeout. + if(TRACE_SELECT) { - if(TRACE_SELECT) - { - trace("timeout"); - } - - _timeout = 0; - shutdown = true; + trace("timeout"); } + + assert(_timeout > 0); + _timeout = 0; + shutdown = true; + continue repeatSelect; } EventHandler handler = null; @@ -764,7 +755,7 @@ public final class ThreadPool } } - private int + private void select() { int ret = 0; @@ -811,8 +802,6 @@ public final class ThreadPool break; } - - return ret; } private void |