Diffusion akantu (bugfixes/ci_deploy_fixes) Browse

ci_deploy_fixes

node_info_per_processor.hh
View Options

			/**
			* @file node_info_per_processor.hh
			*
			* @author Nicolas Richart <nicolas.richart@epfl.ch>
			*
			* @date Fri Mar 11 14:45:15 2016
			*
			* @brief Helper classes to create the distributed synchronizer and distribute
			* a mesh
			*
			* @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 "mesh_accessor.hh"
			/* -------------------------------------------------------------------------- */

			#ifndef __AKANTU_NODE_INFO_PER_PROCESSOR_HH__
			#define __AKANTU_NODE_INFO_PER_PROCESSOR_HH__

			namespace akantu {
			class DistributedSynchronizer;
			class StaticCommunicator;
			}

			/* -------------------------------------------------------------------------- */

			__BEGIN_AKANTU__

			class NodeInfoPerProc : protected MeshAccessor {
			public:
			NodeInfoPerProc(DistributedSynchronizer & synchronizer,
			StaticCommunicator & communicator, UInt message_cnt,
			UInt root, Mesh & mesh);

			virtual void synchronizeNodes() = 0;
			virtual void synchronizeTypes() = 0;
			virtual void synchronizeGroups() = 0;

			protected:
			template <class CommunicationBuffer>
			void fillNodeGroupsFromBuffer(CommunicationBuffer & buffer);
			void fillNodesType();
			protected:
			DistributedSynchronizer & synchronizer;
			StaticCommunicator & comm;
			UInt rank;
			UInt nb_proc;
			UInt root;

			Mesh & mesh;

			UInt spatial_dimension;

			UInt message_count;
			};

			/* -------------------------------------------------------------------------- */
			class MasterNodeInfoPerProc : protected NodeInfoPerProc {
			public:
			MasterNodeInfoPerProc(DistributedSynchronizer & synchronizer,
			StaticCommunicator & communicator, UInt message_cnt,
			UInt root, Mesh & mesh);

			void synchronizeNodes();
			void synchronizeTypes();
			void synchronizeGroups();

			private:
			/// get the list of nodes to send and send them
			std::vector<Array<UInt> > nodes_per_proc;
			Array<UInt> nb_nodes_per_proc;
			};

			/* -------------------------------------------------------------------------- */
			class SlaveNodeInfoPerProc : protected NodeInfoPerProc {
			public:
			SlaveNodeInfoPerProc(DistributedSynchronizer & synchronizer,
			StaticCommunicator & communicator, UInt message_cnt,
			UInt root, Mesh & mesh);

			void synchronizeNodes();
			void synchronizeTypes();
			void synchronizeGroups();

			private:
			};

			__END_AKANTU__

			#include "node_info_per_processor.hh"

			#endif /* __AKANTU_NODE_INFO_PER_PROCESSOR_HH__ */

rAKA/src/synchronizer/node_info_per_processor.hh171d1862ded1bugfixes/ci_deploy_fixes

node_info_per_processor.hhView Options

rAKA/src/synchronizer/node_info_per_processor.hh
171d1862ded1bugfixes/ci_deploy_fixes

node_info_per_processor.hh
View Options