diff options
| author | Alan Conway <aconway@apache.org> | 2006-10-12 18:52:49 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2006-10-12 18:52:49 +0000 |
| commit | c256b20602a42a3d33f36bb0e8d9692906d282a6 (patch) | |
| tree | 0fba6619fbb98c3511785143ca30647c5e6a4469 /cpp/common/io/src/LFProcessor.cpp | |
| parent | 1e6a034ccd8e260e615195bf193aed7d37b928a8 (diff) | |
| download | qpid-python-c256b20602a42a3d33f36bb0e8d9692906d282a6.tar.gz | |
Converted broker to a class for use in tests, plugins etc.
qpid::Exception base class for all exceptions, inherits std::exception.
Require boost on all platforms: http://www.boost.org, 'yum boost' on fedora.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@463376 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/common/io/src/LFProcessor.cpp')
| -rw-r--r-- | cpp/common/io/src/LFProcessor.cpp | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/cpp/common/io/src/LFProcessor.cpp b/cpp/common/io/src/LFProcessor.cpp index 3ac66576e3..65d7451767 100644 --- a/cpp/common/io/src/LFProcessor.cpp +++ b/cpp/common/io/src/LFProcessor.cpp @@ -25,6 +25,9 @@ using namespace qpid::io; using namespace qpid::concurrent; using qpid::QpidError; +// TODO aconway 2006-10-12: stopped is read outside locks. +// + LFProcessor::LFProcessor(apr_pool_t* pool, int _workers, int _size, int _timeout) : size(_size), timeout(_timeout), @@ -46,6 +49,7 @@ LFProcessor::LFProcessor(apr_pool_t* pool, int _workers, int _size, int _timeout LFProcessor::~LFProcessor(){ + if (!stopped) stop(); for(int i = 0; i < workerCount; i++){ delete workers[i]; } |