Diffusion akantu (bugfixes/bug_fix_in_synchronization_of_mat_vec_mul_product_when_assembled_to_residual) Browse

bug_fix_in_syn…

element_info_per_processor.hh
View Options

			/**
			* @file element_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 "aka_common.hh"
			#include "mesh_accessor.hh"
			#include "communication_buffer.hh"
			#include "mesh.hh"
			/* -------------------------------------------------------------------------- */

			#ifndef __AKANTU_ELEMENT_INFO_PER_PROCESSOR_HH__
			#define __AKANTU_ELEMENT_INFO_PER_PROCESSOR_HH__

			namespace akantu {
			class DistributedSynchronizer;
			class StaticCommunicator;
			class MeshPartition;
			}

			/* -------------------------------------------------------------------------- */
			__BEGIN_AKANTU__

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

			virtual void synchronizeConnectivities() = 0;
			virtual void synchronizePartitions() = 0;
			virtual void synchronizeTags() = 0;
			virtual void synchronizeGroups() = 0;

			protected:
			void fillCommunicationScheme(const Array<UInt> & partition);

			template <class CommunicationBuffer>
			void fillElementGroupsFromBuffer(CommunicationBuffer & buffer);

			template <typename T, typename BufferType>
			void fillMeshDataTemplated(BufferType & buffer, const std::string & tag_name);

			template <typename BufferType>
			void fillMeshData(BufferType & buffer, const std::string & tag_name);

			protected:
			DistributedSynchronizer & synchronizer;

			StaticCommunicator & comm;
			UInt rank;
			UInt nb_proc;

			UInt root;

			ElementType type;
			Mesh & mesh;

			UInt nb_tags;
			UInt nb_nodes_per_element;
			UInt nb_element;

			UInt nb_local_element;
			UInt nb_ghost_element;

			UInt message_count;
			};

			/* -------------------------------------------------------------------------- */
			class MasterElementInfoPerProc : protected ElementInfoPerProc {
			public:
			MasterElementInfoPerProc(DistributedSynchronizer & synchronizer,
			StaticCommunicator & communicator, UInt message_cnt,
			UInt root, Mesh & mesh, ElementType type,
			const MeshPartition & partition);

			void synchronizeConnectivities();
			void synchronizePartitions();
			void synchronizeTags();
			void synchronizeGroups();

			protected:
			template <typename T>
			void fillTagBufferTemplated(DynamicCommunicationBuffer * buffers,
			const std::string & tag_name);
			void fillTagBuffer(DynamicCommunicationBuffer * buffers,
			const std::string & tag_name);

			private:
			const MeshPartition & partition;

			Vector<UInt> all_nb_local_element;
			Vector<UInt> all_nb_ghost_element;
			Vector<UInt> all_nb_element_to_send;
			};

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

			void synchronizeConnectivities();
			void synchronizePartitions();
			void synchronizeTags();
			void synchronizeGroups();

			bool needSynchronize();

			private:
			UInt nb_element_to_receive;
			};

			__END_AKANTU__

			#include "element_info_per_processor_tmpl.hh"

			#endif /* __AKANTU_ELEMENT_INFO_PER_PROCESSOR_HH__ */

rAKA/src/synchronizer/element_info_per_processor.hhb1e240aae004bugfixes/bug_fix_in_syn…

element_info_per_processor.hhView Options

rAKA/src/synchronizer/element_info_per_processor.hh
b1e240aae004bugfixes/bug_fix_in_syn…

element_info_per_processor.hh
View Options