summaryrefslogtreecommitdiff
path: root/java/src/IceInternal/ThreadPool.java
diff options
context:
space:
mode:
authorMark Spruiell <mes@zeroc.com>2002-06-28 22:27:13 +0000
committerMark Spruiell <mes@zeroc.com>2002-06-28 22:27:13 +0000
commit8d4be6b08f718253b9ff83edf07a8c9a16f42178 (patch)
tree512293ebf4c40767f74c91cced7e84f0d5dcd1cf /java/src/IceInternal/ThreadPool.java
parentremoving Win32 hacks (diff)
downloadice-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.java31
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