#include <sumi_transport.h>
|
| | sumi_transport (const char *name, sstmac::sw::software_id sid) |
| |
| void | do_smsg_send (int dst, const message::ptr &msg) |
| |
| void | do_rdma_put (int dst, const message::ptr &msg) |
| |
| void | do_rdma_get (int src, const message::ptr &msg) |
| |
| void | do_nvram_get (int src, const message::ptr &msg) |
| |
| void | do_send_terminate (int dst) |
| |
| void | do_send_ping_request (int dst) |
| |
| void | delayed_transport_handle (const message::ptr &msg) |
| |
| void | schedule_ping_timeout (pinger *pnger, double to) |
| |
| void | schedule_next_heartbeat () |
| |
| void | go_die () |
| |
| void | go_revive () |
| |
| | library (const std::string &libname, software_id sid) |
| |
| | library (const char *prefix, software_id sid) |
| |
| void | register_lib (library *lib) |
| | This function is provided so that libraries can instantiate, register, and use other libraries. More...
|
| |
|
| | sumi_api (const char *name, sstmac::sw::software_id sid) |
| |
| virtual | ~sumi_api () |
| |
| virtual void | init_os (sstmac::sw::operating_system *os) |
| |
| sumi::message_ptr | poll_until_notification () |
| |
| sumi::message_ptr | poll_until_notification (timestamp timeout) |
| |
| void | incoming_message (transport_message *msg) |
| |
| void | transport_send (long byte_length, const sumi::message_ptr &msg, int ty, int dst, bool needs_ack) |
| |
| bool | blocked () const |
| |
| | api (const char *name, software_id sid, const key::category &ty) |
| |
| | api (const char *name, software_id sid) |
| |
| virtual | ~api () |
| |
| timestamp | now () const |
| |
| void | schedule (timestamp t, event_queue_entry *ev) |
| |
| void | schedule_delay (timestamp t, event_queue_entry *ev) |
| |
| virtual void | start_api_call () |
| |
| virtual void | end_api_call () |
| |
| virtual void | unregister_all_libs () |
| |
| virtual std::string | to_string () const |
| |
| virtual std::string | lib_name () const |
| |
| virtual void | consume_params (sprockit::sim_parameters *params) |
| |
| operating_system * | os () const |
| |
| software_id | sid () const |
| |
| virtual | ~library () |
| |
| virtual void | init_factory_params (sim_parameters *params) |
| |
| | process_manager (software_id sid) |
| |
| virtual | ~process_manager () |
| |
| int | get_partner (node_id addr) const |
| |
| node_id | my_addr () const |
| |
| void | kill_node () |
| |
| void | kill_process () |
| |
| event_loc_id | loc_ |
| |
| int | rank_ |
| |
| int | nproc_ |
| |
| bool | hostcompute_ |
| |
| Timer * | timer_ |
| |
| long | startcount_ |
| |
| long | endcount_ |
| |
| lib_compute_time * | compute_ |
| |
| operating_system * | os_ |
| |
| key::category | key_cat_ |
| |
| software_id | sid_ |
| |
Definition at line 15 of file sumi_transport.h.
| virtual sumi::sumi_transport::~sumi_transport |
( |
| ) |
|
|
inlineprivatevirtual |
| message::ptr sumi::sumi_transport::block_until_message |
( |
| ) |
|
|
private |
| message::ptr sumi::sumi_transport::block_until_message |
( |
double |
timeout | ) |
|
|
private |
| collective_done_message::ptr sumi::sumi_transport::collective_block |
( |
sumi::collective::type_t |
ty, |
|
|
int |
tag |
|
) |
| |
|
private |
Block on a collective of a particular type and tag until that collective is complete.
- Parameters
-
- Returns
Referenced by ~sumi_transport().
| void sumi::sumi_transport::cq_notify |
( |
| ) |
|
|
private |
| void sumi::sumi_transport::delayed_transport_handle |
( |
const message::ptr & |
msg | ) |
|
|
protected |
| void sumi::sumi_transport::do_nvram_get |
( |
int |
src, |
|
|
const message::ptr & |
msg |
|
) |
| |
|
protected |
| void sumi::sumi_transport::do_rdma_get |
( |
int |
src, |
|
|
const message::ptr & |
msg |
|
) |
| |
|
protected |
| void sumi::sumi_transport::do_rdma_put |
( |
int |
dst, |
|
|
const message::ptr & |
msg |
|
) |
| |
|
protected |
| void sumi::sumi_transport::do_send_ping_request |
( |
int |
dst | ) |
|
|
protected |
| void sumi::sumi_transport::do_send_terminate |
( |
int |
dst | ) |
|
|
protected |
| void sumi::sumi_transport::do_smsg_send |
( |
int |
dst, |
|
|
const message::ptr & |
msg |
|
) |
| |
|
protected |
| virtual void sumi::sumi_transport::finalize |
( |
| ) |
|
|
privatevirtual |
| void sumi::sumi_transport::finalize_init |
( |
| ) |
|
|
privatevirtual |
| void sumi::sumi_transport::go_die |
( |
| ) |
|
|
protected |
| void sumi::sumi_transport::go_revive |
( |
| ) |
|
|
protected |
Implements sstmac::sw::library.
Definition at line 69 of file sumi_transport.h.
References delayed_transport_handle(), do_nvram_get(), do_rdma_get(), do_rdma_put(), do_send_ping_request(), do_send_terminate(), do_smsg_send(), go_die(), go_revive(), schedule_next_heartbeat(), schedule_ping_timeout(), sstmac::sw::library::sid(), and sumi_transport().
| virtual void sumi::sumi_transport::init |
( |
| ) |
|
|
privatevirtual |
| virtual void sumi::sumi_transport::init_factory_params |
( |
sprockit::sim_parameters * |
params | ) |
|
|
privatevirtual |
| void sumi::sumi_transport::ping_timeout |
( |
pinger * |
pnger | ) |
|
|
private |
| void sumi::sumi_transport::schedule_next_heartbeat |
( |
| ) |
|
|
protected |
| void sumi::sumi_transport::schedule_ping_timeout |
( |
pinger * |
pnger, |
|
|
double |
to |
|
) |
| |
|
protected |
| double sumi::sumi_transport::wall_time |
( |
| ) |
const |
|
private |
The documentation for this class was generated from the following file: