Rosetta
|
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 | |
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 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 |
MessageListener id tags note: please add string conversion to util.cc/hh.
Enumerator | |
---|---|
DATABASE_PROTOCOL_AND_BATCH_ID_TAG |
enum basic::mpi::mpi_tags |
std::string basic::mpi::listener_tag_to_name | ( | listener_tags | tag | ) |
References DATABASE_PROTOCOL_AND_BATCH_ID_TAG, enumerate_junctions::default, tag, and numeric::interpolation::to_string().
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 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.
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 data, utility::send_string_to_node(), and utility_exit_with_message.
|
static |
|
static |
|
static |