From bcf9338623912e6a1b79211be0220fbeb2a6a548 Mon Sep 17 00:00:00 2001 From: Alan Conway Date: Thu, 12 Oct 2006 18:52:49 +0000 Subject: 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 --- qpid/cpp/common/io/src/LFProcessor.cpp | 4 ++++ 1 file changed, 4 insertions(+) (limited to 'qpid/cpp/common/io/src/LFProcessor.cpp') 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]; } -- cgit v1.2.1