Rosetta
Classes | Typedefs | Enumerations | Functions | Variables
basic::mpi Namespace Reference

Classes

class  DbMoverMessageListener
 
class  MessageListener
 
class  MessageListenerFactory
 

Typedefs

typedef utility::pointer::shared_ptr< DbMoverMessageListenerDbMoverMessageListenerOP
 
typedef utility::pointer::shared_ptr< DbMoverMessageListener const > DbMoverMessageListenerCOP
 
typedef utility::pointer::shared_ptr< MessageListenerMessageListenerOP
 
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

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)
 

Variables

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

Typedef Documentation

◆ DbMoverMessageListenerCOP

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

◆ DbMoverMessageListenerOP

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

◆ MessageListenerCOP

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

◆ MessageListenerOP

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

Enumeration Type Documentation

◆ listener_tags

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

Enumerator
DATABASE_PROTOCOL_AND_BATCH_ID_TAG 

◆ 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

◆ listener_tag_to_name()

std::string basic::mpi::listener_tag_to_name ( listener_tags  tag)

◆ name_to_listener_tag()

listener_tags basic::mpi::name_to_listener_tag ( std::string const &  listener_tag_name)

◆ request_data_from_head_node() [1/2]

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

◆ request_data_from_head_node() [2/2]

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 data, basic::Tracer::Debug, basic::Tracer::flush(), listener_tag_to_name(), utility::receive_string_from_node(), REQUEST_MESSAGE_TAG, utility::send_string_to_node(), TR, and utility_exit_with_message.

◆ send_data_to_head_node() [1/2]

void basic::mpi::send_data_to_head_node ( std::string const &  data)

◆ send_data_to_head_node() [2/2]

void basic::mpi::send_data_to_head_node ( std::string const &  MPI_ONLYdata)

Variable Documentation

◆ TR [1/3]

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

◆ TR [2/3]

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

◆ TR [3/3]

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