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 | bcf9338623912e6a1b79211be0220fbeb2a6a548 (patch) | |
| tree | d77547bd4ab63f248438b17b5c03f75d2b8d28dc /qpid/cpp/common/io/src/LFProcessor.cpp | |
| parent | 9dd364f138fda7587243ca675173236d2182ba2b (diff) | |
| download | qpid-python-bcf9338623912e6a1b79211be0220fbeb2a6a548.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@463376 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/common/io/src/LFProcessor.cpp')
| -rw-r--r-- | qpid/cpp/common/io/src/LFProcessor.cpp | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/qpid/cpp/common/io/src/LFProcessor.cpp b/qpid/cpp/common/io/src/LFProcessor.cpp index 3ac66576e3..65d7451767 100644 --- a/qpid/cpp/common/io/src/LFProcessor.cpp +++ b/qpid/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]; } |