summaryrefslogtreecommitdiff
path: root/cpp/src/Ice/ThreadPool.cpp
diff options
context:
space:
mode:
authorMarc Laukien <marc@zeroc.com>2001-12-09 19:54:51 +0000
committerMarc Laukien <marc@zeroc.com>2001-12-09 19:54:51 +0000
commitff2cdbada1355055b60e36a53d8bdb160abacc0a (patch)
treece00902f17e79811f65c149354584e8fed440231 /cpp/src/Ice/ThreadPool.cpp
parentfixes (diff)
downloadice-ff2cdbada1355055b60e36a53d8bdb160abacc0a.tar.bz2
ice-ff2cdbada1355055b60e36a53d8bdb160abacc0a.tar.xz
ice-ff2cdbada1355055b60e36a53d8bdb160abacc0a.zip
lots of fixes
Diffstat (limited to 'cpp/src/Ice/ThreadPool.cpp')
-rw-r--r--cpp/src/Ice/ThreadPool.cpp8
1 files changed, 8 insertions, 0 deletions
diff --git a/cpp/src/Ice/ThreadPool.cpp b/cpp/src/Ice/ThreadPool.cpp
index 6c06abedde3..bbe5c2be390 100644
--- a/cpp/src/Ice/ThreadPool.cpp
+++ b/cpp/src/Ice/ThreadPool.cpp
@@ -160,6 +160,9 @@ IceInternal::ThreadPool::ThreadPool(const InstancePtr& instance) :
FD_ZERO(&_fdSet);
FD_SET(_fdIntrRead, &_fdSet);
+#ifdef WIN32 // Optimization for WIN32 fd_set
+ _fdIntrReadIdx = _fdSet.fd_count - 1;
+#endif
_maxFd = _fdIntrRead;
_minFd = _fdIntrRead;
@@ -310,7 +313,12 @@ IceInternal::ThreadPool::run()
}
bool interrupt = false;
+
+#ifdef WIN32 // Optimization for WIN32 fd_set
+ if (fdSet.fd_array[_fdIntrReadIdx] == static_cast<SOCKET>(_fdIntrRead))
+#else
if (FD_ISSET(_fdIntrRead, &fdSet))
+#endif
{
shutdown = clearInterrupt();
interrupt = true;