synchronizer.h

Go to the documentation of this file.

#ifndef WXM_SYNC_SYNCHRONIZER_T_H
#define WXM_SYNC_SYNCHRONIZER_T_H
 
// Wm includes
#include "lib/wmunstructuredpatch.h"
#include "lib/wmudgfunctions.h"
#include "variable/distributed_variable.h"
 
namespace wxm
{
namespace sync
{
 
class patch_synchronizer_t
{
public:
    patch_synchronizer_t(const WmUnstructuredPatch& patch, const int tag_seed)
        : _patch(patch), _tag_seed(tag_seed)
    {
    }
 
    virtual ~patch_synchronizer_t()
    {
    }
 
    virtual void add_component(wxm::variable::distributed_variable_t& variable,
                               const int component_index) = 0;
 
    virtual void sync() = 0;
 
    virtual void sync_nb() = 0;
 
    virtual void sync_nb_wait() = 0;
 
protected:
    const WmUnstructuredPatch& _patch;
 
    int _tag_seed;
};
 
class rank_synchronizer_t
{
public:
    rank_synchronizer_t(const WmDomain& domain) : _domain(domain)
    {
    }
 
    virtual ~rank_synchronizer_t()
    {
    }
 
    virtual void add_component(wxm::variable::distributed_variable_t& variable,
                               const int component_index) = 0;
 
    virtual void sync() = 0;
 
    virtual void sync_nb() = 0;
 
    virtual void sync_nb_wait() = 0;
 
protected:
    const WmDomain& _domain;
};
 
} // namespace sync
} // namespace wxm
 
#endif // SYNCHRONIZER_T_H