basic::mpi Namespace Reference

Classes
class	DbMoverMessageListener
class	MessageListener
class	MessageListenerFactory

Typedefs
typedef utility::pointer::shared_ptr < DbMoverMessageListener >	DbMoverMessageListenerOP
typedef utility::pointer::shared_ptr < DbMoverMessageListener const >	DbMoverMessageListenerCOP
typedef utility::pointer::shared_ptr < MessageListener >	MessageListenerOP
typedef utility::pointer::shared_ptr < MessageListener const >	MessageListenerCOP

Enumerations
enum	listener_tags { DATABASE_PROTOCOL_AND_BATCH_ID_TAG = 42 }
	MessageListener id tags note: please add string conversion to util.cc/hh. More...
enum	mpi_tags {   NEW_JOB_ID_TAG = 10, BAD_INPUT_TAG = 20, JOB_SUCCESS_TAG = 30, JOB_FAILURE_TAG = 40,   REQUEST_MESSAGE_TAG = 50, RECEIVE_MESSAGE_TAG = 60, JOB_GO_TAG = 70 }

Functions
static THREAD_LOCAL basic::Tracer	TR ("basic.mpi.DbMoverMessageListener")
static THREAD_LOCAL basic::Tracer	TR ("basic.mpi.MessageListenerFactory")
static THREAD_LOCAL basic::Tracer	TR ("basic.mpi")
string	request_data_from_head_node (listener_tags MPI_ONLY(listener_tag), string const &MPI_ONLY(data))
	used for message passing to the MPIWorkPoolJobDistributor. This function will ask the head node for data. The type of data returned is based on the type of listener created based on the listener_tags of the MessageListenerFactory More...
void	send_data_to_head_node (std::string const &MPI_ONLY(data))
std::string	listener_tag_to_name (listener_tags tag)
listener_tags	name_to_listener_tag (std::string const &listener_tag_name)
std::string	request_data_from_head_node (listener_tags listener_tag, std::string const &data)
	send mpi message to head node in order to request data. The data sent back will be a string formatted by the listener specified in the listener_tags enum of MessageListenerFactory More...
void	send_data_to_head_node (std::string const &data)

Typedef Documentation

typedef utility::pointer::shared_ptr< DbMoverMessageListener const > basic::mpi::DbMoverMessageListenerCOP

typedef utility::pointer::shared_ptr< DbMoverMessageListener > basic::mpi::DbMoverMessageListenerOP

typedef utility::pointer::shared_ptr< MessageListener const > basic::mpi::MessageListenerCOP

typedef utility::pointer::shared_ptr< MessageListener > basic::mpi::MessageListenerOP

Enumeration Type Documentation

enum basic::mpi::listener_tags

MessageListener id tags note: please add string conversion to util.cc/hh.

Enumerator
DATABASE_PROTOCOL_AND_BATCH_ID_TAG

enum basic::mpi::mpi_tags

Enumerator
NEW_JOB_ID_TAG
BAD_INPUT_TAG
JOB_SUCCESS_TAG
JOB_FAILURE_TAG
REQUEST_MESSAGE_TAG
RECEIVE_MESSAGE_TAG
JOB_GO_TAG

Function Documentation

std::string basic::mpi::listener_tag_to_name

(

listener_tags

tag

)

References DATABASE_PROTOCOL_AND_BATCH_ID_TAG, and tag.

Referenced by request_data_from_head_node().

listener_tags basic::mpi::name_to_listener_tag

(

std::string const &

listener_tag_name

)

References DATABASE_PROTOCOL_AND_BATCH_ID_TAG, and utility_exit_with_message.

std::string basic::mpi::request_data_from_head_node	(	listener_tags	listener_tag,
		std::string const &	data
	)

send mpi message to head node in order to request data. The data sent back will be a string formatted by the listener specified in the listener_tags enum of MessageListenerFactory

string basic::mpi::request_data_from_head_node	(	listener_tags	MPI_ONLYlistener_tag,
		string const &	MPI_ONLYdata
	)

used for message passing to the MPIWorkPoolJobDistributor. This function will ask the head node for data. The type of data returned is based on the type of listener created based on the listener_tags of the MessageListenerFactory

References app.delta_score_per_mutation::data, basic::Tracer::Debug, listener_tag_to_name(), utility::receive_string_from_node(), REQUEST_MESSAGE_TAG, utility::send_string_to_node(), TR(), and utility_exit_with_message.

void basic::mpi::send_data_to_head_node

(

std::string const &

data

)

void basic::mpi::send_data_to_head_node

(

std::string const &

MPI_ONLYdata

)

References app.delta_score_per_mutation::data, utility::send_string_to_node(), and utility_exit_with_message.

static THREAD_LOCAL basic::Tracer basic::mpi::TR ( "basic.mpi.DbMoverMessageListener"  )

static

Referenced by basic::mpi::MessageListenerFactory::get_listener(), and request_data_from_head_node().

static THREAD_LOCAL basic::Tracer basic::mpi::TR ( "basic.mpi"  )

static

static THREAD_LOCAL basic::Tracer basic::mpi::TR ( "basic.mpi.MessageListenerFactory"  )

static