diff options
Diffstat (limited to 'cpp/src/Ice/ThreadPool.cpp')
-rw-r--r-- | cpp/src/Ice/ThreadPool.cpp | 11 |
1 files changed, 7 insertions, 4 deletions
diff --git a/cpp/src/Ice/ThreadPool.cpp b/cpp/src/Ice/ThreadPool.cpp index a4bd00614d4..4618e50d57b 100644 --- a/cpp/src/Ice/ThreadPool.cpp +++ b/cpp/src/Ice/ThreadPool.cpp @@ -35,7 +35,6 @@ IceInternal::ThreadPool::ThreadPool(const InstancePtr& instance, const string& p _sizeMax(0), _sizeWarn(0), _stackSize(0), - _messageSizeMax(0), _running(0), _inUse(0), _load(0), @@ -83,8 +82,6 @@ IceInternal::ThreadPool::ThreadPool(const InstancePtr& instance, const string& p } const_cast<size_t&>(_stackSize) = static_cast<size_t>(stackSize); - const_cast<int&>(_messageSizeMax) = instance->messageSizeMax(); - __setNoDelete(true); try { @@ -231,6 +228,12 @@ IceInternal::ThreadPool::joinWithAllThreads() #endif } +string +IceInternal::ThreadPool::prefix() const +{ + return _prefix; +} + void IceInternal::ThreadPool::clearInterrupt() { @@ -758,7 +761,7 @@ IceInternal::ThreadPool::read(const EventHandlerPtr& handler) { throw IllegalMessageSizeException(__FILE__, __LINE__); } - if(size > _messageSizeMax) + if(size > static_cast<Int>(_instance->messageSizeMax())) { throw MemoryLimitException(__FILE__, __LINE__); } |