Home
last modified time | relevance | path

Searched refs:port_name_tag (Results 1 – 21 of 21) sorted by relevance

/dports/net/mpich/mpich-3.4.3/src/mpid/ch3/src/
H A Dmpid_port.c201 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 Dch3u_port.c256 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 Dmpid_port.c226 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 Dch3u_port.c123 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 Dch3u_connect_sock.c42 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 Dch3u_connect_sock.c43 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 Dofi_spawn.c21 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 Dofi_cm.c42 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 Dofi_msg.c29 match_bits |= (uint64_t)vc->port_name_tag<< \
/dports/net/mpich/mpich-3.4.3/src/mpid/ch3/include/
H A Dmpidimpl.h659 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 Dmpid_port.h49 int port_name_tag; member
/dports/net/mpich2/mpich2-1.5/src/mpid/ch3/channels/nemesis/netmod/tcp/
H A Dsocksm.h180 int port_name_tag; member
H A Dsocksm.c535 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 Dtcp_init.c416 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 Dsocksm.h178 int port_name_tag; member
H A Dsocksm.c511 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 Dtcp_init.c455 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 Dsocksm.h282 int port_name_tag; member
H A Dsocksm.c1074 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 Dwintcp_init.c309 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 Dmpidimpl.h758 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);