Removed NoDistrCommunicator which is now unused (1373faf5) · Commits · TNL / tnl-dev

src/TNL/Communicators/NoDistrCommunicator.h

deleted100644 → 0

+0 −149

Original line number	Diff line number	Diff line
		/***************************************************************************
		NoDistrCommunicator.h - description
		-------------------
		begin : Jan 9, 2018
		copyright : (C) 2018 by Tomas Oberhuber et al.
		email : tomas.oberhuber@fjfi.cvut.cz
		***************************************************************************/

		/* See Copyright Notice in tnl/Copyright */

		#pragma once

		#include <TNL/Logger.h>
		#include <TNL/Config/ConfigDescription.h>
		#include <TNL/Communicators/MpiDefs.h>

		namespace TNL {
		namespace Communicators {

		//! \brief Dummy communicator without any distribution support.
		class NoDistrCommunicator
		{
		public:
		using Request = int;
		using CommunicationGroup = int;
		static constexpr Request NullRequest = -1;
		static constexpr CommunicationGroup AllGroup = 1;
		static constexpr CommunicationGroup NullGroup = 0;

		static void configSetup( Config::ConfigDescription& config, const String& prefix = "" ){};

		static bool setup( const Config::ParameterContainer& parameters,
		const String& prefix = "" )
		{
		return true;
		}

		static void Init(int& argc, char**& argv) {}

		static void setupRedirection(){}

		static void Finalize(){}

		static bool IsInitialized()
		{
		return true;
		}

		static bool isDistributed()
		{
		return false;
		}

		static int GetRank(CommunicationGroup group = AllGroup )
		{
		return 0;
		}

		static int GetSize(CommunicationGroup group = AllGroup )
		{
		return 1;
		}

		static void DimsCreate(int nproc, int dim, int *distr)
		{
		for(int i=0;i<dim;i++)
		{
		distr[i]=1;
		}
		}

		static void Barrier(CommunicationGroup group = AllGroup)
		{
		}

		template <typename T>
		static Request ISend( const T *data, int count, int dest, int tag, CommunicationGroup group)
		{
		return 1;
		}

		template <typename T>
		static Request IRecv( const T *data, int count, int src, int tag, CommunicationGroup group)
		{
		return 1;
		}

		static void WaitAll(Request *reqs, int length)
		{
		}

		template< typename T >
		static void Bcast( T* data, int count, int root, CommunicationGroup group)
		{
		}

		template< typename T >
		static void Allreduce( const T* data,
		T* reduced_data,
		int count,
		const MPI_Op &op,
		CommunicationGroup group )
		{
		memcpy( ( void* ) reduced_data, ( const void* ) data, count * sizeof( T ) );
		}

		// in-place variant of Allreduce
		template< typename T >
		static void Allreduce( T* data,
		int count,
		const MPI_Op &op,
		CommunicationGroup group )
		{
		}

		template< typename T >
		static void Reduce( T* data,
		T* reduced_data,
		int count,
		MPI_Op &op,
		int root,
		CommunicationGroup group )
		{
		memcpy( ( void* ) reduced_data, ( void* ) data, count * sizeof( T ) );
		}

		template< typename T >
		static void Alltoall( const T* sendData,
		int sendCount,
		T* receiveData,
		int receiveCount,
		CommunicationGroup group )
		{
		TNL_ASSERT_EQ( sendCount, receiveCount, "sendCount must be equal to receiveCount for NoDistrCommunicator." );
		memcpy( (void) receiveData, (const void) sendData, sendCount * sizeof( T ) );
		}

		static void CreateNewGroup(bool meToo, int myRank, CommunicationGroup &oldGroup, CommunicationGroup &newGroup)
		{
		newGroup=oldGroup;
		}

		static void writeProlog( Logger& logger )
		{
		}
		};

		} // namespace Communicators
		} // namespace TNL