Homec4science
Diffusion akantu (old-master) Browse

rAKA/synchronizer/ghost_synchronizer.cc
5d2056023c93old-master

Last Change
Raw File

ghost_synchronizer.cc
View Options

/**
* @file ghost_synchronizer.cc
* @author Nicolas Richart <nicolas.richart@epfl.ch>
* @date Tue Aug 24 18:59:17 2010
*
* @brief implementation of the ghost synchronizer
*
* @section LICENSE
*
* Copyright (©) 2010-2011 EPFL (Ecole Polytechnique Fédérale de Lausanne)
* Laboratory (LSMS - Laboratoire de Simulation en Mécanique des Solides)
*
* Akantu is free software: you can redistribute it and/or modify it under the
* terms of the GNU Lesser General Public License as published by the Free
* Software Foundation, either version 3 of the License, or (at your option) any
* later version.
*
* Akantu is distributed in the hope that it will be useful, but WITHOUT ANY
* WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR
* A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more
* details.
*
* You should have received a copy of the GNU Lesser General Public License
* along with Akantu. If not, see <http://www.gnu.org/licenses/>.
*
*/
/* -------------------------------------------------------------------------- */
#include "ghost_synchronizer.hh"
#include "synchronizer.hh"
/* -------------------------------------------------------------------------- */
__BEGIN_AKANTU__
/* -------------------------------------------------------------------------- */
GhostSynchronizer::GhostSynchronizer() :
nb_ghost_synchronization_tags(0) {
AKANTU_DEBUG_IN();
AKANTU_DEBUG_OUT();
}
/* -------------------------------------------------------------------------- */
GhostSynchronizer::~GhostSynchronizer() {
AKANTU_DEBUG_IN();
for (std::list<Synchronizer *>::iterator it = synchronizers.begin();
it != synchronizers.end();
++it) {
delete (*it);
}
synchronizers.clear();
registered_synchronization.clear();
AKANTU_DEBUG_OUT();
}
/* -------------------------------------------------------------------------- */
void GhostSynchronizer::synchronize(GhostSynchronizationTag tag) {
AKANTU_DEBUG_IN();
AKANTU_DEBUG_ASSERT(registered_synchronization.find(tag) != registered_synchronization.end(),
"Tag " << tag << " is not registered.");
AKANTU_DEBUG_INFO("Synchronizing the tag : "
<< registered_synchronization.find(tag)->second
<< " (" << tag <<")");
for (std::list<Synchronizer *>::iterator it = synchronizers.begin();
it != synchronizers.end();
++it) {
(*it)->synchronize(tag);
}
AKANTU_DEBUG_OUT();
}
/* -------------------------------------------------------------------------- */
void GhostSynchronizer::asynchronousSynchronize(GhostSynchronizationTag tag) {
AKANTU_DEBUG_IN();
AKANTU_DEBUG_ASSERT(registered_synchronization.find(tag) != registered_synchronization.end(),
"Tag " << tag << " is not registered.");
for (std::list<Synchronizer *>::iterator it = synchronizers.begin();
it != synchronizers.end();
++it) {
(*it)->asynchronousSynchronize(tag);
}
AKANTU_DEBUG_OUT();
}
/* -------------------------------------------------------------------------- */
void GhostSynchronizer::waitEndSynchronize(GhostSynchronizationTag tag) {
AKANTU_DEBUG_IN();
AKANTU_DEBUG_ASSERT(registered_synchronization.find(tag) != registered_synchronization.end(),
"Tag " << tag << " is not registered.");
for (std::list<Synchronizer *>::iterator it = synchronizers.begin();
it != synchronizers.end();
++it) {
(*it)->waitEndSynchronize(tag);
}
AKANTU_DEBUG_OUT();
}
/* -------------------------------------------------------------------------- */
void GhostSynchronizer::registerTag(GhostSynchronizationTag tag,
const std::string & name) {
AKANTU_DEBUG_IN();
AKANTU_DEBUG_ASSERT(registered_synchronization.find(tag) == registered_synchronization.end(),
"Tag " << tag << " (" << name << ") already registered.");
registered_synchronization[tag] = name;
for (std::list<Synchronizer *>::iterator it = synchronizers.begin();
it != synchronizers.end();
++it) {
(*it)->registerTag(tag);
}
AKANTU_DEBUG_OUT();
}
/* -------------------------------------------------------------------------- */
void GhostSynchronizer::allReduce(Real * values,
const SynchronizerOperation & op,
UInt nb_values) {
AKANTU_DEBUG_IN();
for (std::list<Synchronizer *>::iterator it = synchronizers.begin();
it != synchronizers.end();
++it) {
(*it)->allReduce(values, nb_values, op);
}
AKANTU_DEBUG_OUT();
}
/* -------------------------------------------------------------------------- */
void GhostSynchronizer::registerSynchronizer(Synchronizer & synchronizer) {
AKANTU_DEBUG_IN();
synchronizers.push_back(&synchronizer);
synchronizer.registerGhostSynchronizer(*this);
std::map<GhostSynchronizationTag, std::string>::iterator it;
for (it = registered_synchronization.begin();
it != registered_synchronization.end();
++it) {
synchronizer.registerTag(it->first);
}
AKANTU_DEBUG_OUT();
}
__END_AKANTU__
c4science · Help