Page MenuHomec4science
Files F79218960

lm_communicator.hh
No OneTemporary
Actions

File Metadata

Created
Sun, Aug 25, 08:14

lm_communicator.hh
View Options

/**
* @file communicator.hh
*
* @author Guillaume Anciaux <guillaume.anciaux@epfl.ch>
*
* @date Fri Nov 08 12:44:53 2013
*
* @brief Mother class of LM communicators
*
* @section LICENSE
*
* Copyright INRIA and CEA
*
* The LibMultiScale is a C++ parallel framework for the multiscale
* coupling methods dedicated to material simulations. This framework
* provides an API which makes it possible to program coupled simulations
* and integration of already existing codes.
*
* This Project was initiated in a collaboration between INRIA Futurs Bordeaux
* within ScAlApplix team and CEA/DPTA Ile de France.
* The project is now continued at the Ecole Polytechnique Fédérale de Lausanne
* within the LSMS/ENAC laboratory.
*
* This software is governed by the CeCILL-C license under French law and
* abiding by the rules of distribution of free software. You can use,
* modify and/ or redistribute the software under the terms of the CeCILL-C
* license as circulated by CEA, CNRS and INRIA at the following URL
* "http://www.cecill.info".
*
* As a counterpart to the access to the source code and rights to copy,
* modify and redistribute granted by the license, users are provided only
* with a limited warranty and the software's author, the holder of the
* economic rights, and the successive licensors have only limited
* liability.
*
* In this respect, the user's attention is drawn to the risks associated
* with loading, using, modifying and/or developing or reproducing the
* software by the user in light of its specific status of free software,
* that may mean that it is complicated to manipulate, and that also
* therefore means that it is reserved for developers and experienced
* professionals having in-depth computer knowledge. Users are therefore
* encouraged to load and test the software's suitability as regards their
* requirements in conditions enabling the security of their systems and/or
* data to be ensured and, more generally, to use and operate it in the
* same conditions as regards security.
*
* The fact that you are presently reading this means that you have had
* knowledge of the CeCILL-C license and that you accept its terms.
*
*/
#ifndef __LIBMULTISCALE_COMMUNICATOR_HH__
#define __LIBMULTISCALE_COMMUNICATOR_HH__
/* -------------------------------------------------------------------------- */
#include "comm_buffer.hh"
#include "comm_group.hh"
#include "id_manager.hh"
#include "tensor.hh"
#include <memory>
#include <mpi.h>
/* -------------------------------------------------------------------------- */
__BEGIN_LIBMULTISCALE__
/* -------------------------------------------------------------------------- */
class Geometry;
/* -------------------------------------------------------------------------- */
class Communicator : public IDManager<CommGroup> {
public:
Communicator();
virtual ~Communicator();
//! return the communicator used
static Communicator &getCommunicator();
//! create the communicator
static void createCommunicator();
//! add a group of nb_proc processors
void addGroup(const LMID &id, UInt nb_procs);
//! return the number of registered objects
static UInt getNbGroups();
//! get the groups
static decltype(objects) &getGroups();
//! get a group by its name
static CommGroup &getGroup(const LMID &id);
//! return the number of still free processors
UInt getNumberFreeProcs();
//! wait for unsynchronisated comunications
void waitForPendingComs();
inline void sendLocalGeometriesToGroup(Geometry &geom, CommGroup &group);
inline void receiveLocalGeometriesFromGroup(Geometry **geom,
CommGroup &group);
inline void sendCommunicationTable(std::vector<UInt> &com_with,
CommGroup &destgroup);
inline void receiveCommunicationTable(std::vector<UInt> &com_with,
CommGroup &fromgroup);
};
/* -------------------------------------------------------------------------- */
// template <typename T>
// inline void Communicator::receive(std::vector<T> &d, UInt from,
// CommGroup &group,
// const std::string &comment) {
// CommBuffer<T> buf(d);
// receive(buf, from, group, comment);
// }
// /* --------------------------------------------------------------------------
// */
// template <typename T>
// inline void Communicator::receive(std::vector<T> &d, UInt nb, UInt from,
// CommGroup &group,
// const std::string &comment) {
// CommBuffer<T> buf(d);
// receive(buf, nb, from, group, comment);
// }
// /* --------------------------------------------------------------------------
// */
// template <typename T>
// inline void Communicator::send(std::vector<T> &d, UInt nb, UInt from,
// CommGroup &group, const std::string &comment)
// {
// CommBuffer<T> buf(d);
// send(buf, nb, from, group, comment);
// }
// /* --------------------------------------------------------------------------
// */
// template <typename T>
// inline void Communicator::send(std::vector<T> &d, UInt from, CommGroup
// &group,
// const std::string &comment) {
// send(d, d.size(), from, group, comment);
// }
// /* --------------------------------------------------------------------------
// */
// template <typename T>
// inline void Communicator::receive(CommBuffer<T> &d, UInt from, CommGroup
// &group,
// const std::string &comment) {
// receive(d, UINT_MAX, from, group, comment);
// }
// /* --------------------------------------------------------------------------
// */
// template <>
// inline void Communicator::receive(CommBuffer<Real> &d, UInt nb, UInt from,
// CommGroup &group,
// const std::string &comment) {
// receiveReals(d, nb, from, group, comment);
// }
// /* --------------------------------------------------------------------------
// */
// template <>
// inline void Communicator::send(CommBuffer<Real> &d, UInt nb, UInt to,
// CommGroup &group, const std::string &comment)
// {
// sendReals(d, nb, to, group, comment);
// }
// /* --------------------------------------------------------------------------
// */
// template <typename T>
// inline void Communicator::send(CommBuffer<T> &d, UInt nb, UInt to,
// CommGroup &group, const std::string &comment)
// {
// UInt nb_uint = nb * sizeof(T) / sizeof(UInt);
// if (sizeof(T) % sizeof(UInt) != 0)
// LM_FATAL("have to reimplement this shit");
// std::vector<UInt> buf(nb_uint);
// memcpy(&buf[0], d.buffer(), sizeof(UInt) * nb_uint);
// auto c_buf = CommBuffer<UInt>(buf);
// sendUInts(c_buf, nb_uint, to, group, comment);
// }
// /* --------------------------------------------------------------------------
// */
// template <>
// inline void Communicator::send(CommBuffer<UInt> &d, UInt nb, UInt to,
// CommGroup &group, const std::string &comment)
// {
// sendUInts(d, nb, to, group, comment);
// }
// /* --------------------------------------------------------------------------
// */
// template <>
// inline void Communicator::receive(CommBuffer<UInt> &d, UInt nb, UInt from,
// CommGroup &group,
// const std::string &comment) {
// receiveUInts(d, nb, from, group, comment);
// }
// /* --------------------------------------------------------------------------
// */
// template <typename T>
// inline void Communicator::receive(CommBuffer<T> &d, UInt nb, UInt from,
// CommGroup &group,
// const std::string &comment) {
// UInt nb_uint = nb * sizeof(T) / sizeof(UInt);
// if (sizeof(T) % sizeof(UInt) != 0)
// LM_FATAL("have to reimplement this shit");
// std::vector<UInt> buf(nb_uint);
// auto c_buf = CommBuffer<UInt>(buf);
// receiveUInts(c_buf, nb_uint, from, group, comment);
// memcpy(d.buffer(), &buf[0], sizeof(UInt) * nb_uint);
// }
// /* --------------------------------------------------------------------------
// */
// template <typename T>
// inline void Communicator::send(CommBuffer<T> &d, UInt from, CommGroup &group,
// const std::string &comment) {
// send(d, d.size(), from, group, comment);
// }
// /* --------------------------------------------------------------------------
// */
// template <>
// inline void Communicator::reduce(CommBuffer<Real> &d, UInt nb, CommGroup
// &group,
// const std::string &comment, Operator op) {
// reduceReal(d, nb, group, comment, op);
// }
// /* --------------------------------------------------------------------------
// */
// template <>
// inline void Communicator::reduce(CommBuffer<UInt> &d, UInt nb, CommGroup
// &group,
// const std::string &comment, Operator op) {
// reduceUInt(d, nb, group, comment, op);
// }
// /* --------------------------------------------------------------------------
// */
// template <typename T>
// inline void Communicator::reduce(std::vector<T> &d, UInt nb, CommGroup
// &group,
// const std::string &comment, Operator op) {
// CommBuffer<T> buf(d);
// reduce(buf, nb, group, comment, op);
// }
// /* --------------------------------------------------------------------------
// */
// template <typename T>
// inline void Communicator::reduce(T *d, UInt nb, CommGroup &group,
// const std::string &comment, Operator op) {
// CommBuffer<T> buf;
// buf.resize(nb);
// std::copy(d, d + nb, buf.buffer());
// reduce(buf, nb, group, comment, op);
// std::copy(buf.buffer(), buf.buffer() + nb, d);
// }
// /* --------------------------------------------------------------------------
// */
// template <>
// inline void Communicator::broadcast(CommBuffer<Real> & d,UInt nb,CommGroup
// group,
// const std::string & comment){
// broadcastReal(d,nb,group,comment);
// }
// /* --------------------------------------------------------------------------
// */
// template <>
// inline void Communicator::broadcast(CommBuffer<UInt> & d,UInt nb,CommGroup
// group,
// const std::string & comment){
// broadcastUInt(d,nb,group,comment);
// }
// /* --------------------------------------------------------------------------
// */
// template <typename T>
// inline void Communicator::broadcast(std::vector<T> & d,UInt nb,CommGroup
// group,
// const std::string & comment){
// CommBuffer<T> buf(d);
// broadcast(buf,nb,group,comment);
// }
// /* --------------------------------------------------------------------------
// */
// template <typename T>
// inline void Communicator::broadcast(T *d,UInt nb,CommGroup group,
// const std::string & comment){
// CommBuffer<T> buf;
// buf.resize(nb);
// std::copy(d,d+nb,buf.buffer());
// broadcast(buf,nb,group,comment);
// std::copy(buf.buffer(),buf.buffer()+nb,d);
// }
// /* --------------------------------------------------------------------------
// */
// template <>
// inline void Communicator::gather(CommBuffer<Real> & d,UInt nb,
// CommBuffer<Real> & e,
// UInt to, CommGroup group, const std::string &
// comment){
// gatherReal(d,nb,e,to,group,comment);
// }
// /* --------------------------------------------------------------------------
// */
// template <>
// inline void Communicator::gather(CommBuffer<UInt> & d,UInt nb,
// CommBuffer<UInt> & e,
// UInt to, CommGroup group,const std::string &
// comment){
// gatherUInt(d,nb,e,to,group,comment);
// }
// /* --------------------------------------------------------------------------
// */
// template <typename T>
// inline void Communicator::gather(std::vector<T> & d,UInt nb, std::vector<T> &
// e,
// UInt to, CommGroup group, const std::string &
// comment){
// CommBuffer<T> buf1(d);
// CommBuffer<T> buf2(e);
// gather(buf1,nb,buf2,to,group,comment);
// }
// /* --------------------------------------------------------------------------
// */
// template <typename T>
// inline void Communicator::gather(T *d,UInt nb,T *e,UInt to,CommGroup group,
// const std::string & comment){
// // CommBuffer<T> buf1;
// // buf1.resize(nb);
// // std::copy(d,d+nb,buf1.buffer());
// // CommBuffer<T> buf2;
// // buf2.resize(nb);
// // std::copy(e,e+nb,buf2.buffer());
// gather(d,nb,e,to,group,comment);
// // // std::copy(buf1.buffer(),buf1.buffer()+nb,d);
// // // std::copy(buf2.buffer(),buf2.buffer()+nb,d);
// }
/* -------------------------------------------------------------------------- */
// template <>
// inline void Communicator::allReduce(CommBuffer<Real> &d, UInt nb,
// CommGroup &group,
// const std::string &comment, Operator op)
// {
// allReduceReal(d, nb, group, comment, op);
// }
// /* --------------------------------------------------------------------------
// */
// template <>
// inline void Communicator::allReduce(CommBuffer<UInt> &d, UInt nb,
// CommGroup &group,
// const std::string &comment, Operator op)
// {
// allReduceUInt(d, nb, group, comment, op);
// }
// /* --------------------------------------------------------------------------
// */
// template <typename T>
// inline void Communicator::allReduce(std::vector<T> &d, UInt nb,
// CommGroup &group,
// const std::string &comment, Operator op)
// {
// CommBuffer<T> buf(d);
// allReduce(buf, nb, group, comment, op);
// }
// /* --------------------------------------------------------------------------
// */
// template <typename T>
// inline void Communicator::allReduce(T *d, UInt nb, CommGroup &group,
// const std::string &comment, Operator op)
// {
// CommBuffer<T> buf;
// buf.resize(nb);
// std::copy(d, d + nb, buf.buffer());
// allReduce(buf, nb, group, comment, op);
// std::copy(buf.buffer(), buf.buffer() + nb, d);
// }
// /* --------------------------------------------------------------------------
// */
// inline void Communicator::allReduce(Tensor &d, UInt nb, CommGroup &group,
// const std::string &comment, Operator op)
// {
// allReduce(d.getVec(), d.size(), group, comment, op);
// }
// /* --------------------------------------------------------------------------
// */
// template <typename T>
// inline void Communicator::send(T *d, UInt nb, UInt to, CommGroup &group,
// const std::string &comment) {
// CommBuffer<T> buf;
// buf.resize(nb);
// std::copy(d, d + nb, buf.buffer());
// send(buf, nb, to, group, comment);
// }
// /* --------------------------------------------------------------------------
// */
// template <typename T>
// inline void Communicator::receive(T *d, UInt nb, UInt from, CommGroup &group,
// const std::string &comment) {
// CommBuffer<T> buf;
// buf.resize(nb);
// receive(buf, nb, from, group, comment);
// std::copy(buf.buffer(), buf.buffer() + nb, d);
// }
// /* --------------------------------------------------------------------------
// */
// inline std::ostream &operator<<(std::ostream &os, Communicator &c) {
// c.printself(os);
// return os;
// }
// /* --------------------------------------------------------------------------
// */
__END_LIBMULTISCALE__
//#include "communicator_world.hh"
//__BEGIN_LIBMULTISCALE__
// static WorldCommunicator WORLD_COMMUNICATOR;
///* --------------------------------------------------------------------------
///*/
//__END_LIBMULTISCALE__
#endif /* __LIBMULTISCALE_COMMUNICATOR_HH__ */

Event Timeline

c4science · Help