http://bugzilla.zeroc.com/bugzilla/show_bug.cgi?id=1179

1 files changed, 43 insertions, 0 deletions

diff --git a/cpp/src/Ice/ThreadPool.cpp b/cpp/src/Ice/ThreadPool.cpp
index 5b16ee748eb..5240889b537 100644
--- a/cpp/src/Ice/ThreadPool.cpp
+++ b/cpp/src/Ice/ThreadPool.cpp
@@ -60,6 +60,7 @@ IceInternal::ThreadPool::ThreadPool(const InstancePtr& instance, const string& p
     _minFd = _fdIntrRead;
 
 #if defined(_WIN32)
+    _fdsInUse = 1; // _fdIntrRead is always in use.
     FD_ZERO(&_fdSet);
     FD_SET(_fdIntrRead, &_fdSet);
 #elif defined(__linux)
@@ -210,6 +211,48 @@ IceInternal::ThreadPool::destroy()
 }
 
 void
+IceInternal::ThreadPool::incFdsInUse()
+{
+    // This is windows specific since every other platform uses an API
+    // that doesn't have a specific FD limit.
+#ifdef _WIN32
+    IceUtil::Monitor<IceUtil::Mutex>::Lock sync(*this);
+    assert(!_destroyed);
+    if(_fdsInUse + 1 > FD_SETSIZE)
+    {
+	Warning warn(_instance->initializationData().logger);
+	warn << "maximum number of connections exceeded";
+
+	//
+	// No appropriate errno.
+	//
+	SocketException ex(__FILE__, __LINE__);
+	ex.error = 0;
+	throw ex;
+    }
+    ++_fdsInUse;
+#endif
+}
+
+void
+IceInternal::ThreadPool::decFdsInUse()
+{
+    // This is windows specific since every other platform uses an API
+    // that doesn't have a specific FD limit.
+#ifdef _WIN32
+    IceUtil::Monitor<IceUtil::Mutex>::Lock sync(*this);
+    assert(!_destroyed);
+    if(_fdsInUse <= 1)
+    {
+	Trace trace(_instance->initializationData().logger, "ThreadPool");
+	trace << _prefix << ": about to assert";
+    }
+    assert(_fdsInUse > 1); // _fdIntrRead is always in use.
+    --_fdsInUse;
+#endif
+}
+
+void
 IceInternal::ThreadPool::_register(SOCKET fd, const EventHandlerPtr& handler)
 {
     IceUtil::Monitor<IceUtil::Mutex>::Lock sync(*this);