You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@etch.apache.org by ve...@apache.org on 2012/10/17 08:51:35 UTC
svn commit: r1399123 -
/incubator/etch/trunk/binding-cpp/runtime/src/main/support/EtchQueuedPool.cpp
Author: veithm
Date: Wed Oct 17 06:51:35 2012
New Revision: 1399123
URL: http://svn.apache.org/viewvc?rev=1399123&view=rev
Log:
ETCH-244 Fixing QueuedPool todo
Change-Id: I43f88546ad2e6212e6fa6f99baa822c85107b46d
Modified:
incubator/etch/trunk/binding-cpp/runtime/src/main/support/EtchQueuedPool.cpp
Modified: incubator/etch/trunk/binding-cpp/runtime/src/main/support/EtchQueuedPool.cpp
URL: http://svn.apache.org/viewvc/incubator/etch/trunk/binding-cpp/runtime/src/main/support/EtchQueuedPool.cpp?rev=1399123&r1=1399122&r2=1399123&view=diff
==============================================================================
--- incubator/etch/trunk/binding-cpp/runtime/src/main/support/EtchQueuedPool.cpp (original)
+++ incubator/etch/trunk/binding-cpp/runtime/src/main/support/EtchQueuedPool.cpp Wed Oct 17 06:51:35 2012
@@ -88,9 +88,10 @@ status_t EtchQueuedPool::add(capu::Smart
if(!mIsOpen) {
return ETCH_EINVAL;
}
+ if(mPool->getSize() + 1 > mSizeMax)
+ return ETCH_ENOT_SUPPORTED;
EtchQueuedPoolRunnable* pr = new EtchQueuedPoolRunnable(this, runnable);
- //TODO: check max Size before adding a new Runnable
capu::status_t status = mPool->add(pr);
if(status != capu::CAPU_OK) {
return ETCH_ERROR;