AsynchronousOperator.h

Go to the documentation of this file.

#ifndef included_AMP_AsynchronousOperator
#define included_AMP_AsynchronousOperator
 
#include "AMP/operators/AsynchronousOperatorParameters.h"
#include "AMP/operators/Operator.h"
#include "AMP/utils/AMP_MPI.h"
 
#include <vector>
 
 
namespace AMP::Operator {
 
 
class AsynchronousOperator : public Operator
{
protected:
    std::vector<AMP_MPI::Request> d_RequestList;
 
    void reserveRequests( size_t i );
 
    void clearRequests();
 
    std::vector<AMP_MPI::Request>::iterator beginRequests();
 
    std::vector<AMP_MPI::Request>::iterator endRequests();
 
    AMP_MPI::Request &getRequest( size_t i );
 
    void waitForAllRequests();
 
 
    template<typename T>
    T *getBufferToAvoidDebugVectorCrashing( std::vector<T> &in )
    {
        T *retVal = 0;
        if ( in.size() > 0 )
            retVal = &( in[0] );
        return retVal;
    }
 
    template<typename T>
    const T *getBufferToAvoidDebugVectorCrashing( const std::vector<T> &in )
    {
        const T *retVal = 0;
        if ( in.size() > 0 )
            retVal = &( in[0] );
        return retVal;
    }
 
 
public:
    explicit AsynchronousOperator( std::shared_ptr<const OperatorParameters> params );
 
    virtual ~AsynchronousOperator();
 
    std::string type() const override { return "AsynchronousOperator"; }
 
    virtual void applyStart( AMP::LinearAlgebra::Vector::const_shared_ptr u,
                             AMP::LinearAlgebra::Vector::shared_ptr f ) = 0;
 
    virtual void applyFinish( AMP::LinearAlgebra::Vector::const_shared_ptr u,
                              AMP::LinearAlgebra::Vector::shared_ptr f ) = 0;
 
    virtual void apply( AMP::LinearAlgebra::Vector::const_shared_ptr u,
                        AMP::LinearAlgebra::Vector::shared_ptr f ) override;
};
} // namespace AMP::Operator
 
 
#endif