diff options
| author | Marc Laukien <marc@zeroc.com> | 2003-03-07 19:41:12 +0000 |
|---|---|---|
| committer | Marc Laukien <marc@zeroc.com> | 2003-03-07 19:41:12 +0000 |
| commit | 909902165af20518131b43d2fb05e5c7234f016f (patch) | |
| tree | efad7b12a59e08d0c10ac9d1d3900c641e6c5056 /cpp/src/Ice/Instance.cpp | |
| parent | internal thread pool changes (diff) | |
| download | ice-909902165af20518131b43d2fb05e5c7234f016f.tar.bz2 ice-909902165af20518131b43d2fb05e5c7234f016f.tar.xz ice-909902165af20518131b43d2fb05e5c7234f016f.zip | |
dyn thread pool
Diffstat (limited to 'cpp/src/Ice/Instance.cpp')
| -rw-r--r-- | cpp/src/Ice/Instance.cpp | 23 |
1 files changed, 16 insertions, 7 deletions
diff --git a/cpp/src/Ice/Instance.cpp b/cpp/src/Ice/Instance.cpp index 3b32c71d510..06c1148d161 100644 --- a/cpp/src/Ice/Instance.cpp +++ b/cpp/src/Ice/Instance.cpp @@ -207,6 +207,22 @@ IceInternal::Instance::clientThreadPool() if(!_clientThreadPool) // Lazy initialization. { + // + // Make sure that the client thread pool defaults are correctly + // + if(_properties->getProperty("Ice.ThreadPool.Client.Size").empty()) + { + _properties->setProperty("Ice.ThreadPool.Client.Size", "1"); + } + if(_properties->getProperty("Ice.ThreadPool.Client.SizeMax").empty()) + { + _properties->setProperty("Ice.ThreadPool.Client.SizeMax", "1"); + } + if(_properties->getProperty("Ice.ThreadPool.Client.SizeWarn").empty()) + { + _properties->setProperty("Ice.ThreadPool.Client.SizeWarn", "0"); + } + _clientThreadPool = new ThreadPool(this, "Ice.ThreadPool.Client", 0); } @@ -222,13 +238,6 @@ IceInternal::Instance::serverThreadPool() if(!_serverThreadPool) // Lazy initialization. { - // - // Make sure that the server thread pool default is set - // correctly. - // - _properties->setProperty("Ice.ThreadPool.Server.Size", - _properties->getPropertyWithDefault("Ice.ThreadPool.Server.Size", "10")); - int timeout = _properties->getPropertyAsInt("Ice.ServerIdleTime"); _serverThreadPool = new ThreadPool(this, "Ice.ThreadPool.Server", timeout); } |