|| || || || || || || ||

---

PatReduceOp.h

Go to the documentation of this file.

#ifndef Impala_Core_Array_Pattern_PatReduceOp_h
#define Impala_Core_Array_Pattern_PatReduceOp_h

#include "Core/Array/Trait/ReduceAdaptor.h"
#include "Core/Array/Pattern/FuncInOut.h"

#ifdef PX_HORUS_USED
#include "Core/Array/Pattern/PxArrayFunc.h"
#include "Core/Array/Pattern/PxStateTrans.h"
#endif

namespace Impala
{
namespace Core
{
namespace Array
{
namespace Pattern
{


template<class ArrayT, class ReduceT>
inline typename ArrayT::ArithType
PatReduceOp(ArrayT* src, ReduceT& pixOp)
{
    Trait::ReduceAdaptor<ReduceT> redOp;
    typedef typename ArrayT::ArithType ArithT;
    ArithT total;

#ifdef PX_HORUS_USED
    if (!PxRunParallel()) {                         // run sequential
#endif
        FuncInOutDispatch(src, redOp);
        total = redOp.Result();

#ifdef PX_HORUS_USED
    } else {                                        // run parallel
        PxArrayPreStateTrans(src, PAR_PART, STRONG);
        FuncInOutDispatch(PxArrayPD(src), redOp);
        total = redOp.Result();
        total = PxReduceValueToAll(total, pixOp, PX_MPI);

        if (!PxRunLazyParallel()) {
            PxArrayForceNonDistributed(src);
        }
    }
#endif

    return total;
}

} // namespace Pattern
} // namespace Array
} // namespace Core
} // namespace Impala

#endif

---