mca_oob_tcp_peer_t 120 orte/mca/oob/tcp/oob_tcp.c mca_oob_tcp_peer_t *peer; mca_oob_tcp_peer_t 178 orte/mca/oob/tcp/oob_tcp.c mca_oob_tcp_peer_t *peer; mca_oob_tcp_peer_t 255 orte/mca/oob/tcp/oob_tcp.c mca_oob_tcp_peer_t *peer; mca_oob_tcp_peer_t 341 orte/mca/oob/tcp/oob_tcp.c mca_oob_tcp_peer_t* peer = (mca_oob_tcp_peer_t*)item; mca_oob_tcp_peer_t 191 orte/mca/oob/tcp/oob_tcp_common.c mca_oob_tcp_peer_t* mca_oob_tcp_peer_lookup(const orte_process_name_t *name) mca_oob_tcp_peer_t 193 orte/mca/oob/tcp/oob_tcp_common.c mca_oob_tcp_peer_t *peer; mca_oob_tcp_peer_t 33 orte/mca/oob/tcp/oob_tcp_common.h ORTE_MODULE_DECLSPEC mca_oob_tcp_peer_t* mca_oob_tcp_peer_lookup(const orte_process_name_t *name); mca_oob_tcp_peer_t 671 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_peer_t *peer; mca_oob_tcp_peer_t 831 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_peer_t *pr; mca_oob_tcp_peer_t 930 orte/mca/oob/tcp/oob_tcp_component.c pr = OBJ_NEW(mca_oob_tcp_peer_t); mca_oob_tcp_peer_t 1328 orte/mca/oob/tcp/oob_tcp_component.c static void peer_cons(mca_oob_tcp_peer_t *peer) mca_oob_tcp_peer_t 1344 orte/mca/oob/tcp/oob_tcp_component.c static void peer_des(mca_oob_tcp_peer_t *peer) mca_oob_tcp_peer_t 1368 orte/mca/oob/tcp/oob_tcp_component.c OBJ_CLASS_INSTANCE(mca_oob_tcp_peer_t, mca_oob_tcp_peer_t 86 orte/mca/oob/tcp/oob_tcp_connection.c static void tcp_peer_event_init(mca_oob_tcp_peer_t* peer); mca_oob_tcp_peer_t 87 orte/mca/oob/tcp/oob_tcp_connection.c static int tcp_peer_send_connect_ack(mca_oob_tcp_peer_t* peer); mca_oob_tcp_peer_t 90 orte/mca/oob/tcp/oob_tcp_connection.c static bool tcp_peer_recv_blocking(mca_oob_tcp_peer_t* peer, int sd, mca_oob_tcp_peer_t 92 orte/mca/oob/tcp/oob_tcp_connection.c static void tcp_peer_connected(mca_oob_tcp_peer_t* peer); mca_oob_tcp_peer_t 94 orte/mca/oob/tcp/oob_tcp_connection.c static int tcp_peer_create_socket(mca_oob_tcp_peer_t* peer, sa_family_t family) mca_oob_tcp_peer_t 161 orte/mca/oob/tcp/oob_tcp_connection.c mca_oob_tcp_peer_t *peer; mca_oob_tcp_peer_t 401 orte/mca/oob/tcp/oob_tcp_connection.c static int tcp_peer_send_connect_ack(mca_oob_tcp_peer_t* peer) mca_oob_tcp_peer_t 506 orte/mca/oob/tcp/oob_tcp_connection.c static void tcp_peer_event_init(mca_oob_tcp_peer_t* peer) mca_oob_tcp_peer_t 544 orte/mca/oob/tcp/oob_tcp_connection.c void mca_oob_tcp_peer_complete_connect(mca_oob_tcp_peer_t *peer) mca_oob_tcp_peer_t 665 orte/mca/oob/tcp/oob_tcp_connection.c static bool retry(mca_oob_tcp_peer_t* peer, int sd, bool fatal) mca_oob_tcp_peer_t 720 orte/mca/oob/tcp/oob_tcp_connection.c int mca_oob_tcp_peer_recv_connect_ack(mca_oob_tcp_peer_t* pr, mca_oob_tcp_peer_t 727 orte/mca/oob/tcp/oob_tcp_connection.c mca_oob_tcp_peer_t *peer; mca_oob_tcp_peer_t 804 orte/mca/oob/tcp/oob_tcp_connection.c peer = OBJ_NEW(mca_oob_tcp_peer_t); mca_oob_tcp_peer_t 954 orte/mca/oob/tcp/oob_tcp_connection.c static void tcp_peer_connected(mca_oob_tcp_peer_t* peer) mca_oob_tcp_peer_t 990 orte/mca/oob/tcp/oob_tcp_connection.c void mca_oob_tcp_peer_close(mca_oob_tcp_peer_t *peer) mca_oob_tcp_peer_t 1055 orte/mca/oob/tcp/oob_tcp_connection.c static bool tcp_peer_recv_blocking(mca_oob_tcp_peer_t* peer, int sd, mca_oob_tcp_peer_t 1143 orte/mca/oob/tcp/oob_tcp_connection.c void mca_oob_tcp_peer_dump(mca_oob_tcp_peer_t* peer, const char* msg) mca_oob_tcp_peer_t 1216 orte/mca/oob/tcp/oob_tcp_connection.c bool mca_oob_tcp_peer_accept(mca_oob_tcp_peer_t* peer) mca_oob_tcp_peer_t 42 orte/mca/oob/tcp/oob_tcp_connection.h mca_oob_tcp_peer_t *peer; mca_oob_tcp_peer_t 95 orte/mca/oob/tcp/oob_tcp_connection.h ORTE_MODULE_DECLSPEC void mca_oob_tcp_peer_dump(mca_oob_tcp_peer_t* peer, const char* msg); mca_oob_tcp_peer_t 96 orte/mca/oob/tcp/oob_tcp_connection.h ORTE_MODULE_DECLSPEC bool mca_oob_tcp_peer_accept(mca_oob_tcp_peer_t* peer); mca_oob_tcp_peer_t 97 orte/mca/oob/tcp/oob_tcp_connection.h ORTE_MODULE_DECLSPEC void mca_oob_tcp_peer_complete_connect(mca_oob_tcp_peer_t* peer); mca_oob_tcp_peer_t 98 orte/mca/oob/tcp/oob_tcp_connection.h ORTE_MODULE_DECLSPEC int mca_oob_tcp_peer_recv_connect_ack(mca_oob_tcp_peer_t* peer, mca_oob_tcp_peer_t 100 orte/mca/oob/tcp/oob_tcp_connection.h ORTE_MODULE_DECLSPEC void mca_oob_tcp_peer_close(mca_oob_tcp_peer_t *peer); mca_oob_tcp_peer_t 66 orte/mca/oob/tcp/oob_tcp_peer.h OBJ_CLASS_DECLARATION(mca_oob_tcp_peer_t); mca_oob_tcp_peer_t 86 orte/mca/oob/tcp/oob_tcp_sendrecv.c mca_oob_tcp_peer_t *peer; mca_oob_tcp_peer_t 89 orte/mca/oob/tcp/oob_tcp_sendrecv.c peer = (mca_oob_tcp_peer_t*)snd->peer; mca_oob_tcp_peer_t 114 orte/mca/oob/tcp/oob_tcp_sendrecv.c static int send_msg(mca_oob_tcp_peer_t* peer, mca_oob_tcp_send_t* msg) mca_oob_tcp_peer_t 203 orte/mca/oob/tcp/oob_tcp_sendrecv.c mca_oob_tcp_peer_t* peer = (mca_oob_tcp_peer_t*)cbdata; mca_oob_tcp_peer_t 346 orte/mca/oob/tcp/oob_tcp_sendrecv.c static int read_bytes(mca_oob_tcp_peer_t* peer) mca_oob_tcp_peer_t 431 orte/mca/oob/tcp/oob_tcp_sendrecv.c mca_oob_tcp_peer_t* peer = (mca_oob_tcp_peer_t*)cbdata; mca_oob_tcp_peer_t 37 orte/mca/oob/tcp/oob_tcp_sendrecv.h struct mca_oob_tcp_peer_t; mca_oob_tcp_peer_t 43 orte/mca/oob/tcp/oob_tcp_sendrecv.h struct mca_oob_tcp_peer_t *peer; mca_oob_tcp_peer_t 84 orte/mca/oob/tcp/oob_tcp_sendrecv.h (s)->peer = (struct mca_oob_tcp_peer_t*)(p); \