utility::SimulateMPIData Class Reference

#include <SimulateMPI.hh>

Public Types
typedef std::list < SimulateMPIMessageOP >	MsgQueue

Public Member Functions
	SimulateMPIData (platform::Size nprocs)
int	mpi_nprocs () const
void	queue_message (SimulateMPIMessageOP msg)
SimulateMPIMessageOP	pop_next_message_for_node_of_type (platform::Size dst, simulate_mpi_message_type msg_type)
SimulateMPIMessageOP	pop_next_message_of_type (platform::Size dst, platform::Size src, simulate_mpi_message_type msg_type)

Private Member Functions
void	clear_processed_msgs (MsgQueue &)

Private Attributes
platform::Size	mpi_nprocs_
platform::Size	nmessages_
MsgQueue	all_messages_
vector0< MsgQueue >	messages_for_node_
vector0< MsgQueue >	messages_from_node_
vector0< vector0< MsgQueue > >	messages_

Member Typedef Documentation

typedef std::list< SimulateMPIMessageOP > utility::SimulateMPIData::MsgQueue

Constructor & Destructor Documentation

utility::SimulateMPIData::SimulateMPIData

(

platform::Size

nprocs

)

References messages_.

Member Function Documentation

void utility::SimulateMPIData::clear_processed_msgs ( MsgQueue &  message_queue )

private

Erase elements of the queue that have already been processed until we arrive at an element that has not yet been processed and then return.

Referenced by pop_next_message_for_node_of_type(), and pop_next_message_of_type().

int utility::SimulateMPIData::mpi_nprocs ( ) const

inline

References mpi_nprocs_.

Referenced by utility::SimulateMPI::mpi_nprocs().

SimulateMPIMessageOP utility::SimulateMPIData::pop_next_message_for_node_of_type	(	platform::Size	dst,
		simulate_mpi_message_type	msg_type
	)

References clear_processed_msgs(), basic::options::OptionKeys::score::empty, messages_, mpi_nprocs_, utility::msg_name(), and utility::to_string().

Referenced by utility::SimulateMPI::receive_integer_from_anyone().

SimulateMPIMessageOP utility::SimulateMPIData::pop_next_message_of_type	(	platform::Size	dst,
		platform::Size	src,
		simulate_mpi_message_type	msg_type
	)

References clear_processed_msgs(), basic::options::OptionKeys::score::empty, messages_, utility::msg_name(), and utility::to_string().

Referenced by utility::SimulateMPI::receive_char_from_node(), utility::SimulateMPI::receive_double_from_node(), utility::SimulateMPI::receive_doubles_from_node(), utility::SimulateMPI::receive_integer_from_node(), utility::SimulateMPI::receive_integers_from_node(), and utility::SimulateMPI::receive_string_from_node().

void utility::SimulateMPIData::queue_message

(

SimulateMPIMessageOP

msg

)

References all_messages_, messages_, messages_for_node_, messages_from_node_, and nmessages_.

Referenced by utility::SimulateMPI::send_char_to_node(), utility::SimulateMPI::send_double_to_node(), utility::SimulateMPI::send_doubles_to_node(), utility::SimulateMPI::send_integer_to_node(), utility::SimulateMPI::send_integers_to_node(), and utility::SimulateMPI::send_string_to_node().

Member Data Documentation

MsgQueue utility::SimulateMPIData::all_messages_

private

Referenced by queue_message().

vector0< vector0< MsgQueue > > utility::SimulateMPIData::messages_

private

Referenced by pop_next_message_for_node_of_type(), pop_next_message_of_type(), queue_message(), and SimulateMPIData().

vector0< MsgQueue > utility::SimulateMPIData::messages_for_node_

private

Referenced by queue_message().

vector0< MsgQueue > utility::SimulateMPIData::messages_from_node_

private

Referenced by queue_message().

platform::Size utility::SimulateMPIData::mpi_nprocs_

private

Referenced by mpi_nprocs(), and pop_next_message_for_node_of_type().

platform::Size utility::SimulateMPIData::nmessages_

private

Referenced by queue_message().

---

The documentation for this class was generated from the following files:

• src/utility/SimulateMPI.hh
• src/utility/SimulateMPI.cc