synchronizer.h

Go to the documentation of this file.

#ifndef WXM_DFEM_SYNC_SYNCHRONIZER_T_H
#define WXM_DFEM_SYNC_SYNCHRONIZER_T_H
 
// Wm includes
#include "lib/wmunstructuredpatch.h"
#include "lib/wmudgfunctions.h"
#include "variables/wmvariable.h"
#include "sync/synchronizer.h"
#include "dfem/sync/tools/exchange.h"
#include "dfem/variable/distributed_variable.h"
 
// Wx includes
#include "lib/wxmsgbase.h"
 
namespace wxm
{
namespace dfem
{
namespace sync
{
 
class patch_synchronizer_t : public wxm::sync::patch_synchronizer_t
{
public:
    patch_synchronizer_t(const WmUnstructuredPatch& patch, const int tag_seed);
 
    virtual ~patch_synchronizer_t();
 
    void add_component(wxm::variable::distributed_variable_t& variable,
                       const int component_index)
    {
        add_component(
            dynamic_cast<wxm::dfem::variable::distributed_variable_t&>(variable),
            component_index);
    }
 
    void sync();
 
    void sync_nb();
 
    void sync_nb_wait();
 
protected:
    void add_component(wxm::dfem::variable::distributed_variable_t& variable,
                       const int component_index);
 
    void finalize();
 
    bool _finalized;
 
    tools::patch_exchanges_t _send_transfers;
 
    tools::patch_exchanges_t _recv_transfers;
};
 
class rank_synchronizer_t : public wxm::sync::rank_synchronizer_t
{
public:
    rank_synchronizer_t(const WmDomain& domain);
 
    ~rank_synchronizer_t();
 
    void add_component(wxm::variable::distributed_variable_t& variable,
                       const int component_index)
    {
        add_component(
            dynamic_cast<wxm::dfem::variable::distributed_variable_t&>(variable),
            component_index);
    }
 
    void sync();
 
    void sync_nb();
 
    void sync_nb_wait();
 
protected:
    void add_component(wxm::dfem::variable::distributed_variable_t& variable,
                       const int component_index);
 
    void finalize();
 
    bool _finalized;
 
    tools::rank_exchanges_t _send_transfers;
 
    tools::rank_exchanges_t _recv_transfers;
};
 
} // namespace sync
} // namespace dfem
} // namespace wxm
 
#endif // SYNCHRONIZER_T_H