/home/brandes/workspace/LAMA/src/lama/pgas/functor/PGASMaxLocFunctor.hpp

Go to the documentation of this file.

#ifndef LAMA_PGASMAXLOCFUNCTOR_HPP_
#define LAMA_PGASMAXLOCFUNCTOR_HPP_

#include <lama/pgas/PGASInterface.hpp>
#include <lama/pgas/PGASFunctor.hpp>

namespace lama{
template <typename T>
class PGASMaxLocFunctor: public PGASFunctor
{
    T* mResult;
    T* mWork;
    int* mWorkRank;
    int* mResultRank;
    const PGASInterface* const mInterface;

public:
    PGASMaxLocFunctor(T val);
    virtual ~PGASMaxLocFunctor();
    virtual void iteration(int partner, bool active);
    T getResult();
    int getLoc();
};

template <typename T>
PGASMaxLocFunctor<T>::PGASMaxLocFunctor(T val): mInterface(PGASInterface::getInstance())
{
    mResult = static_cast<T*>(mInterface->allocate(sizeof(T)));
    mWork = static_cast<T*>(mInterface->allocate(sizeof(T)));
    mResultRank = static_cast<int*>(mInterface->allocate(sizeof(int)));
    *mWork = val;
    *mResult = val;
    *mResultRank = mInterface->getRank();
}
template <typename T>
PGASMaxLocFunctor<T>::~PGASMaxLocFunctor()
{
    mInterface->free(mWork,sizeof(T));
    mInterface->free(mResult,sizeof(T));
    mInterface->free(mResultRank,sizeof(int));
}

template <typename T>
T PGASMaxLocFunctor<T>::getResult()
{
    return *mResult;
}

template <typename T>
int PGASMaxLocFunctor<T>::getLoc()
{
    return *mResultRank;
}

template <typename T>
void PGASMaxLocFunctor<T>::iteration(int partner, bool active)
{
    mInterface->syncronizeAll();
    *mWork = *mResult;
    mInterface->syncronizeAll();
    if(active)
    {
        mInterface->get(mWork,mResult,sizeof(T),partner);

        if(((*mWork)>(*mResult)))
        {
            *mResult = *mWork;
            mInterface->get(mResultRank,mResultRank,sizeof(int),partner);
        }
    }
}
}//namespace lama

#endif // LAMA_PGASMAXLOCFUNCTOR_HPP_