109 lines
3.5 KiB
C++
109 lines
3.5 KiB
C++
// Copyright (C) 2007 Douglas Gregor
|
|
|
|
// Use, modification and distribution is subject to the Boost Software
|
|
// License, Version 1.0. (See accompanying file LICENSE_1_0.txt or copy at
|
|
// http://www.boost.org/LICENSE_1_0.txt)
|
|
|
|
// This file contains a simplification of the "trigger" method for
|
|
// process groups. The simple trigger handles the common case where
|
|
// the handler associated with a trigger is a member function bound to
|
|
// a particular pointer.
|
|
|
|
#ifndef BOOST_GRAPH_PARALLEL_SIMPLE_TRIGGER_HPP
|
|
#define BOOST_GRAPH_PARALLEL_SIMPLE_TRIGGER_HPP
|
|
|
|
#ifndef BOOST_GRAPH_USE_MPI
|
|
#error "Parallel BGL files should not be included unless <boost/graph/use_mpi.hpp> has been included"
|
|
#endif
|
|
|
|
#include <boost/graph/parallel/process_group.hpp>
|
|
|
|
namespace boost { namespace graph { namespace parallel {
|
|
|
|
namespace detail {
|
|
|
|
/**
|
|
* INTERNAL ONLY
|
|
*
|
|
* The actual function object that bridges from the normal trigger
|
|
* interface to the simplified interface. This is the equivalent of
|
|
* bind(pmf, self, _1, _2, _3, _4), but without the compile-time
|
|
* overhead of bind.
|
|
*/
|
|
template<typename Class, typename T, typename Result>
|
|
class simple_trigger_t
|
|
{
|
|
public:
|
|
simple_trigger_t(Class* self,
|
|
Result (Class::*pmf)(int, int, const T&,
|
|
trigger_receive_context))
|
|
: self(self), pmf(pmf) { }
|
|
|
|
Result
|
|
operator()(int source, int tag, const T& data,
|
|
trigger_receive_context context) const
|
|
{
|
|
return (self->*pmf)(source, tag, data, context);
|
|
}
|
|
|
|
private:
|
|
Class* self;
|
|
Result (Class::*pmf)(int, int, const T&, trigger_receive_context);
|
|
};
|
|
|
|
} // end namespace detail
|
|
|
|
/**
|
|
* Simplified trigger interface that reduces the amount of code
|
|
* required to connect a process group trigger to a handler that is
|
|
* just a bound member function.
|
|
*
|
|
* INTERNAL ONLY
|
|
*/
|
|
template<typename ProcessGroup, typename Class, typename T>
|
|
inline void
|
|
simple_trigger(ProcessGroup& pg, int tag, Class* self,
|
|
void (Class::*pmf)(int source, int tag, const T& data,
|
|
trigger_receive_context context), int)
|
|
{
|
|
pg.template trigger<T>(tag,
|
|
detail::simple_trigger_t<Class, T, void>(self, pmf));
|
|
}
|
|
|
|
/**
|
|
* Simplified trigger interface that reduces the amount of code
|
|
* required to connect a process group trigger with a reply to a
|
|
* handler that is just a bound member function.
|
|
*
|
|
* INTERNAL ONLY
|
|
*/
|
|
template<typename ProcessGroup, typename Class, typename T, typename Result>
|
|
inline void
|
|
simple_trigger(ProcessGroup& pg, int tag, Class* self,
|
|
Result (Class::*pmf)(int source, int tag, const T& data,
|
|
trigger_receive_context context), long)
|
|
{
|
|
pg.template trigger_with_reply<T>
|
|
(tag, detail::simple_trigger_t<Class, T, Result>(self, pmf));
|
|
}
|
|
|
|
/**
|
|
* Simplified trigger interface that reduces the amount of code
|
|
* required to connect a process group trigger to a handler that is
|
|
* just a bound member function.
|
|
*/
|
|
template<typename ProcessGroup, typename Class, typename T, typename Result>
|
|
inline void
|
|
simple_trigger(ProcessGroup& pg, int tag, Class* self,
|
|
Result (Class::*pmf)(int source, int tag, const T& data,
|
|
trigger_receive_context context))
|
|
{
|
|
// We pass 0 (an int) to help VC++ disambiguate calls to simple_trigger
|
|
// with Result=void.
|
|
simple_trigger(pg, tag, self, pmf, 0);
|
|
}
|
|
|
|
} } } // end namespace boost::graph::parallel
|
|
|
|
#endif // BOOST_GRAPH_PARALLEL_SIMPLE_TRIGGER_HPP
|