/dports/net/mpich/mpich-3.4.3/src/mpid/ch3/src/ |
H A D | mpid_port.c | 201 static int get_port_name_tag(int * port_name_tag) in get_port_name_tag() argument 223 *port_name_tag = ((i * 8 * (int)sizeof(int)) + j); in get_port_name_tag() 237 *port_name_tag = -1; in get_port_name_tag() 260 int port_name_tag = 0; /* this tag is added to the business card, in MPIDI_Open_port() local 267 mpi_errno = get_port_name_tag(&port_name_tag); in MPIDI_Open_port() 286 mpi_errno = MPIDI_CH3I_Port_init(port_name_tag); in MPIDI_Open_port() 301 int port_name_tag; in MPIDI_Close_port() local 306 mpi_errno = MPIDI_GetTagFromPort(port_name, &port_name_tag); in MPIDI_Close_port() 309 free_port_name_tag(port_name_tag); in MPIDI_Close_port() 311 mpi_errno = MPIDI_CH3I_Port_destroy(port_name_tag); in MPIDI_Close_port() [all …]
|
H A D | ch3u_port.c | 256 int port_name_tag; in MPIDI_Create_inter_root_communicator_connect() local 271 mpi_errno = MPIDI_GetTagFromPort( port_name, &port_name_tag); in MPIDI_Create_inter_root_communicator_connect() 373 int port_name_tag; in MPIDI_Create_inter_root_communicator_accept() local 1464 LL_SEARCH_SCALAR(active_portq.head, port, port_name_tag, port_name_tag); in MPIDI_CH3I_Acceptq_enqueue() 1488 connreq, port_name_tag, vc)); in MPIDI_CH3I_Acceptq_enqueue() 1495 connreq, port_name_tag, vc)); in MPIDI_CH3I_Acceptq_enqueue() 1522 LL_SEARCH_SCALAR(active_portq.head, port, port_name_tag, port_name_tag); in MPIDI_CH3I_Acceptq_dequeue() 1796 int MPIDI_CH3I_Port_init(int port_name_tag) in MPIDI_CH3I_Port_init() argument 1808 port->port_name_tag = port_name_tag; in MPIDI_CH3I_Port_init() 1826 int MPIDI_CH3I_Port_destroy(int port_name_tag) in MPIDI_CH3I_Port_destroy() argument [all …]
|
/dports/net/mpich2/mpich2-1.5/src/mpid/ch3/src/ |
H A D | mpid_port.c | 226 static int get_port_name_tag(int * port_name_tag) in get_port_name_tag() argument 248 *port_name_tag = ((i * 8 * sizeof(int)) + j); in get_port_name_tag() 262 *port_name_tag = -1; in get_port_name_tag() 289 int port_name_tag = 0; /* this tag is added to the business card, in MPIDI_Open_port() local 296 mpi_errno = get_port_name_tag(&port_name_tag); in MPIDI_Open_port() 301 MPIDI_CH3I_PORT_NAME_TAG_KEY, port_name_tag); in MPIDI_Open_port() 332 int port_name_tag; in MPIDI_Close_port() local 337 mpi_errno = MPIDI_GetTagFromPort(port_name, &port_name_tag); in MPIDI_Close_port() 340 free_port_name_tag(port_name_tag); in MPIDI_Close_port() 353 int MPIDI_GetTagFromPort( const char *port_name, int *port_name_tag ) in MPIDI_GetTagFromPort() argument [all …]
|
H A D | ch3u_port.c | 123 int port_name_tag; in MPIDI_Create_inter_root_communicator_connect() local 138 mpi_errno = MPIDI_GetTagFromPort( port_name, &port_name_tag); in MPIDI_Create_inter_root_communicator_connect() 173 int port_name_tag; in MPIDI_Create_inter_root_communicator_accept() local 179 mpi_errno = MPIDI_GetTagFromPort( port_name, &port_name_tag); in MPIDI_Create_inter_root_communicator_accept() 194 MPIDI_CH3I_Acceptq_dequeue(&new_vc, port_name_tag); in MPIDI_Create_inter_root_communicator_accept() 1261 int port_name_tag; member 1274 int MPIDI_CH3I_Acceptq_enqueue(MPIDI_VC_t * vc, int port_name_tag ) in MPIDI_CH3I_Acceptq_enqueue() argument 1294 q_item->port_name_tag = port_name_tag; in MPIDI_CH3I_Acceptq_enqueue() 1318 int MPIDI_CH3I_Acceptq_dequeue(MPIDI_VC_t ** vc, int port_name_tag) in MPIDI_CH3I_Acceptq_dequeue() argument 1332 if (q_item->port_name_tag == port_name_tag) in MPIDI_CH3I_Acceptq_dequeue() [all …]
|
/dports/net/mpich/mpich-3.4.3/src/mpid/ch3/util/sock/ |
H A D | ch3u_connect_sock.c | 42 int port_name_tag; member 199 int port, port_name_tag; in MPIDI_CH3I_Connect_to_root_sock() local 226 mpi_errno = MPIDI_GetTagFromPort(port_name, &port_name_tag); in MPIDI_CH3I_Connect_to_root_sock() 231 MPL_DBG_MSG_D(MPIDI_CH3_DBG_CONNECT,VERBOSE,"port tag %d",port_name_tag); in MPIDI_CH3I_Connect_to_root_sock() 264 acceptpkt->port_name_tag = port_name_tag; in MPIDI_CH3I_Connect_to_root_sock() 561 int port_name_tag; in MPIDI_CH3_Sockconn_handle_connect_event() local 572 port_name_tag = acceptpkt->port_name_tag; in MPIDI_CH3_Sockconn_handle_connect_event() 574 acceptpkt->port_name_tag = port_name_tag; in MPIDI_CH3_Sockconn_handle_connect_event() 686 int port_name_tag; in MPIDI_CH3_Sockconn_handle_conn_event() local 710 port_name_tag = acceptpkt->port_name_tag; in MPIDI_CH3_Sockconn_handle_conn_event() [all …]
|
/dports/net/mpich2/mpich2-1.5/src/mpid/ch3/util/sock/ |
H A D | ch3u_connect_sock.c | 43 int port_name_tag; member 216 int port, port_name_tag; in MPIDI_CH3I_Connect_to_root_sock() local 245 mpi_errno = MPIDI_GetTagFromPort(port_name, &port_name_tag); in MPIDI_CH3I_Connect_to_root_sock() 250 MPIU_DBG_MSG_D(CH3_CONNECT,VERBOSE,"port tag %d",port_name_tag); in MPIDI_CH3I_Connect_to_root_sock() 285 acceptpkt->port_name_tag = port_name_tag; in MPIDI_CH3I_Connect_to_root_sock() 615 int port_name_tag; in MPIDI_CH3_Sockconn_handle_connect_event() local 626 port_name_tag = acceptpkt->port_name_tag; in MPIDI_CH3_Sockconn_handle_connect_event() 628 acceptpkt->port_name_tag = port_name_tag; in MPIDI_CH3_Sockconn_handle_connect_event() 742 int port_name_tag; in MPIDI_CH3_Sockconn_handle_conn_event() local 766 port_name_tag = acceptpkt->port_name_tag; in MPIDI_CH3_Sockconn_handle_conn_event() [all …]
|
/dports/net/mpich/mpich-3.4.3/src/mpid/ch4/netmod/ofi/ |
H A D | ofi_spawn.c | 21 static int get_port_name_tag(int *port_name_tag); 22 static int get_tag_from_port(const char *port_name, int *port_name_tag); 52 static int get_port_name_tag(int *port_name_tag) in get_port_name_tag() argument 70 *port_name_tag = ((i * 8 * sizeof(int)) + j); in get_port_name_tag() 82 *port_name_tag = -1; in get_port_name_tag() 87 static int get_tag_from_port(const char *port_name, int *port_name_tag) in get_tag_from_port() argument 679 int port_name_tag = 0; in MPIDI_OFI_mpi_open_port() local 689 mpi_errno = get_port_name_tag(&port_name_tag); in MPIDI_OFI_mpi_open_port() 706 int port_name_tag; in MPIDI_OFI_mpi_close_port() local 716 mpi_errno = get_tag_from_port(port_name, &port_name_tag); in MPIDI_OFI_mpi_close_port() [all …]
|
/dports/net/mpich/mpich-3.4.3/src/mpid/ch3/channels/nemesis/netmod/ofi/ |
H A D | ofi_cm.c | 42 while (vc && vc->port_name_tag != port) { in ofi_wc_to_vc() 119 MPIDI_CH3I_NM_OFI_RC(MPIDI_GetTagFromPort(bc, &vc->port_name_tag)); in MPID_nem_ofi_conn_req_callback() 132 MPIDI_CH3I_Acceptq_enqueue(vc, vc->port_name_tag); in MPID_nem_ofi_conn_req_callback() 540 MPIDI_CH3I_NM_OFI_RC(MPIDI_GetTagFromPort(business_card, &new_vc->port_name_tag)); in MPID_nem_ofi_connect_to_root() 548 str_errno = MPL_str_add_int_arg(&bc, &my_bc_len, "tag", new_vc->port_name_tag); in MPID_nem_ofi_connect_to_root()
|
H A D | ofi_msg.c | 29 match_bits |= (uint64_t)vc->port_name_tag<< \
|
/dports/net/mpich/mpich-3.4.3/src/mpid/ch3/include/ |
H A D | mpidimpl.h | 659 int port_name_tag; /* added to handle dynamic process mgmt */ member 988 int MPIDI_CH3I_Acceptq_enqueue(MPIDI_VC_t * vc, int port_name_tag); 991 int MPIDI_CH3I_Port_init(int port_name_tag); 992 int MPIDI_CH3I_Port_destroy(int port_name_tag); 996 #define MPIDI_CH3I_Acceptq_enqueue(vc, port_name_tag) (MPI_SUCCESS) argument 999 #define MPIDI_CH3I_Port_init(port_name_tag) (MPI_SUCCESS) argument 1000 #define MPIDI_CH3I_Port_destroy(port_name_tag) (MPI_SUCCESS) argument 1647 #define MPIDI_GetTagFromPort(port_name, port_name_tag) (MPI_SUCCESS) argument
|
H A D | mpid_port.h | 49 int port_name_tag; member
|
/dports/net/mpich2/mpich2-1.5/src/mpid/ch3/channels/nemesis/netmod/tcp/ |
H A D | socksm.h | 180 int port_name_tag; member
|
H A D | socksm.c | 535 port_info.port_name_tag = sc->vc->port_name_tag; in send_tmpvc_info() 661 iov[0].iov_base = (void *) &(sc->vc->port_name_tag); in recv_id_or_tmpvc_info() 662 iov[0].iov_len = sizeof(sc->vc->port_name_tag); in recv_id_or_tmpvc_info() 671 …IU_DBG_FDEST, "enqueuing on acceptq vc=%p, sc->fd=%d, tag=%d", vc, sc->fd, sc->vc->port_name_tag)); in recv_id_or_tmpvc_info() 672 MPIDI_CH3I_Acceptq_enqueue(vc, sc->vc->port_name_tag); in recv_id_or_tmpvc_info()
|
H A D | tcp_init.c | 416 mpi_errno = MPIDI_GetTagFromPort(business_card, &new_vc->port_name_tag); in MPID_nem_tcp_connect_to_root()
|
/dports/net/mpich/mpich-3.4.3/src/mpid/ch3/channels/nemesis/netmod/tcp/ |
H A D | socksm.h | 178 int port_name_tag; member
|
H A D | socksm.c | 511 port_info.port_name_tag = sc->vc->port_name_tag; in send_tmpvc_info() 657 iov[0].iov_base = (void *) &(sc->vc->port_name_tag); in recv_id_or_tmpvc_info() 658 iov[0].iov_len = sizeof(sc->vc->port_name_tag); in recv_id_or_tmpvc_info() 671 sc->vc->port_name_tag)); in recv_id_or_tmpvc_info() 672 MPIDI_CH3I_Acceptq_enqueue(vc, sc->vc->port_name_tag); in recv_id_or_tmpvc_info()
|
H A D | tcp_init.c | 455 mpi_errno = MPIDI_GetTagFromPort(business_card, &new_vc->port_name_tag); in MPID_nem_tcp_connect_to_root()
|
/dports/net/mpich2/mpich2-1.5/src/mpid/ch3/channels/nemesis/netmod/wintcp/ |
H A D | socksm.h | 282 int port_name_tag; member
|
H A D | socksm.c | 1074 port_info.port_name_tag = sc->vc->port_name_tag; in send_tmpvc_info() 1324 iov[0].MPID_IOV_BUF = (void *) &(sc->vc->port_name_tag); in recv_id_or_tmpvc_info_success_handler() 1325 iov[0].MPID_IOV_LEN = sizeof(sc->vc->port_name_tag); in recv_id_or_tmpvc_info_success_handler() 1338 …IU_DBG_FDEST, "enqueuing on acceptq vc=%p, sc->fd=%d, tag=%d", vc, sc->fd, sc->vc->port_name_tag)); in recv_id_or_tmpvc_info_success_handler() 1339 MPIDI_CH3I_Acceptq_enqueue(vc, sc->vc->port_name_tag); in recv_id_or_tmpvc_info_success_handler()
|
H A D | wintcp_init.c | 309 mpi_errno = MPIDI_GetTagFromPort(business_card, &new_vc->port_name_tag); in MPID_nem_newtcp_module_connect_to_root()
|
/dports/net/mpich2/mpich2-1.5/src/mpid/ch3/include/ |
H A D | mpidimpl.h | 758 int port_name_tag; /* added to handle dynamic process mgmt */ member 1094 int MPIDI_CH3I_Acceptq_enqueue(MPIDI_VC_t * vc, int port_name_tag); 1095 int MPIDI_CH3I_Acceptq_dequeue(MPIDI_VC_t ** vc, int port_name_tag);
|