From e65b0086a2924ff04640b1350393a816249d01b3 Mon Sep 17 00:00:00 2001 From: Alan Conway Date: Thu, 17 Jul 2008 00:03:50 +0000 Subject: Cluster: shadow connections, fix lifecycle & valgrind issues. - tests/ForkedBroker: improved broker forking, exec full qpidd. - Plugin::addFinalizer - more flexible way to shutdown plugins. - Reworked cluster extension points using boost::function. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@677471 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/Plugin.cpp | 17 +++++++++++------ 1 file changed, 11 insertions(+), 6 deletions(-) (limited to 'cpp/src/qpid/Plugin.cpp') diff --git a/cpp/src/qpid/Plugin.cpp b/cpp/src/qpid/Plugin.cpp index b8206499ae..e4b76db28a 100644 --- a/cpp/src/qpid/Plugin.cpp +++ b/cpp/src/qpid/Plugin.cpp @@ -35,15 +35,20 @@ Plugin::Plugins& thePlugins() { return plugins; } -void call(boost::function f) { f(); } +void invoke(boost::function f) { f(); } } // namespace -Plugin::Target::~Target() { - std::for_each(cleanup.begin(), cleanup.end(), &call); +Plugin::Target::~Target() { finalize(); } + +void Plugin::Target::finalize() { + for_each(finalizers.begin(), finalizers.end(), invoke); + finalizers.clear(); } -void Plugin::Target::addCleanup(const boost::function& f) { cleanup.push_back(f); } +void Plugin::Target::addFinalizer(const boost::function& f) { + finalizers.push_back(f); +} Plugin::Plugin() { // Register myself. @@ -69,7 +74,7 @@ void Plugin::addOptions(Options& opts) { } } -void Plugin::earlyInitAll(Target& t) { each_plugin(boost::bind(&Plugin::earlyInitialize, _1, t)); } -void Plugin::initAll(Target& t) { each_plugin(boost::bind(&Plugin::initialize, _1, t)); } +void Plugin::earlyInitAll(Target& t) { each_plugin(boost::bind(&Plugin::earlyInitialize, _1, boost::ref(t))); } +void Plugin::initializeAll(Target& t) { each_plugin(boost::bind(&Plugin::initialize, _1, boost::ref(t))); } } // namespace qpid -- cgit v1.2.1