ctxt_id            82 ompi/mca/mtl/ofi/mtl_ofi.h #define MTL_OFI_CONTEXT_LOCK(ctxt_id) \
ctxt_id            83 ompi/mca/mtl/ofi/mtl_ofi.h OPAL_LIKELY(!opal_mutex_atomic_trylock(&ompi_mtl_ofi.ofi_ctxt[ctxt_id].context_lock))
ctxt_id            85 ompi/mca/mtl/ofi/mtl_ofi.h #define MTL_OFI_CONTEXT_UNLOCK(ctxt_id) \
ctxt_id            86 ompi/mca/mtl/ofi/mtl_ofi.h opal_mutex_atomic_unlock(&ompi_mtl_ofi.ofi_ctxt[ctxt_id].context_lock)
ctxt_id            89 ompi/mca/mtl/ofi/mtl_ofi.h ompi_mtl_ofi_context_progress(int ctxt_id)
ctxt_id           105 ompi/mca/mtl/ofi/mtl_ofi.h         ret = fi_cq_read(ompi_mtl_ofi.ofi_ctxt[ctxt_id].cq, (void *)&wc,
ctxt_id           129 ompi/mca/mtl/ofi/mtl_ofi.h             ret = fi_cq_readerr(ompi_mtl_ofi.ofi_ctxt[ctxt_id].cq,
ctxt_id           170 ompi/mca/mtl/ofi/mtl_ofi.h     int count = 0, ctxt_id = 0, i;
ctxt_id           173 ompi/mca/mtl/ofi/mtl_ofi.h     get_thread_context(&ctxt_id);
ctxt_id           176 ompi/mca/mtl/ofi/mtl_ofi.h         if (MTL_OFI_CONTEXT_LOCK(ctxt_id)) {
ctxt_id           177 ompi/mca/mtl/ofi/mtl_ofi.h             count += ompi_mtl_ofi_context_progress(ctxt_id);
ctxt_id           178 ompi/mca/mtl/ofi/mtl_ofi.h             MTL_OFI_CONTEXT_UNLOCK(ctxt_id);
ctxt_id           181 ompi/mca/mtl/ofi/mtl_ofi.h         count += ompi_mtl_ofi_context_progress(ctxt_id);
ctxt_id           193 ompi/mca/mtl/ofi/mtl_ofi.h             ctxt_id = (ctxt_id + 1) % ompi_mtl_ofi.total_ctxts_used;
ctxt_id           195 ompi/mca/mtl/ofi/mtl_ofi.h             if (MTL_OFI_CONTEXT_LOCK(ctxt_id)) {
ctxt_id           196 ompi/mca/mtl/ofi/mtl_ofi.h                 count += ompi_mtl_ofi_context_progress(ctxt_id);
ctxt_id           197 ompi/mca/mtl/ofi/mtl_ofi.h                 MTL_OFI_CONTEXT_UNLOCK(ctxt_id);
ctxt_id           351 ompi/mca/mtl/ofi/mtl_ofi.h     int ctxt_id = 0;
ctxt_id           353 ompi/mca/mtl/ofi/mtl_ofi.h     ctxt_id = ompi_mtl_ofi_map_comm_to_ctxt(comm->c_contextid);
ctxt_id           354 ompi/mca/mtl/ofi/mtl_ofi.h     set_thread_context(ctxt_id);
ctxt_id           365 ompi/mca/mtl/ofi/mtl_ofi.h     MTL_OFI_RETRY_UNTIL_DONE(fi_trecv(ompi_mtl_ofi.ofi_ctxt[ctxt_id].rx_ep,
ctxt_id           397 ompi/mca/mtl/ofi/mtl_ofi.h     int ompi_ret, ctxt_id = 0;
ctxt_id           408 ompi/mca/mtl/ofi/mtl_ofi.h     ctxt_id = ompi_mtl_ofi_map_comm_to_ctxt(comm->c_contextid);
ctxt_id           409 ompi/mca/mtl/ofi/mtl_ofi.h     set_thread_context(ctxt_id);
ctxt_id           421 ompi/mca/mtl/ofi/mtl_ofi.h     sep_peer_fiaddr = fi_rx_addr(endpoint->peer_fiaddr, ctxt_id, ompi_mtl_ofi.rx_ctx_bits);
ctxt_id           450 ompi/mca/mtl/ofi/mtl_ofi.h             MTL_OFI_RETRY_UNTIL_DONE(fi_tinjectdata(ompi_mtl_ofi.ofi_ctxt[ctxt_id].tx_ep,
ctxt_id           457 ompi/mca/mtl/ofi/mtl_ofi.h             MTL_OFI_RETRY_UNTIL_DONE(fi_tinject(ompi_mtl_ofi.ofi_ctxt[ctxt_id].tx_ep,
ctxt_id           468 ompi/mca/mtl/ofi/mtl_ofi.h                 fi_cancel((fid_t)ompi_mtl_ofi.ofi_ctxt[ctxt_id].tx_ep, &ack_req->ctx);
ctxt_id           478 ompi/mca/mtl/ofi/mtl_ofi.h             MTL_OFI_RETRY_UNTIL_DONE(fi_tsenddata(ompi_mtl_ofi.ofi_ctxt[ctxt_id].tx_ep,
ctxt_id           487 ompi/mca/mtl/ofi/mtl_ofi.h             MTL_OFI_RETRY_UNTIL_DONE(fi_tsend(ompi_mtl_ofi.ofi_ctxt[ctxt_id].tx_ep,
ctxt_id           533 ompi/mca/mtl/ofi/mtl_ofi.h     int ompi_ret, ctxt_id = 0;
ctxt_id           543 ompi/mca/mtl/ofi/mtl_ofi.h     ctxt_id = ompi_mtl_ofi_map_comm_to_ctxt(comm->c_contextid);
ctxt_id           544 ompi/mca/mtl/ofi/mtl_ofi.h     set_thread_context(ctxt_id);
ctxt_id           553 ompi/mca/mtl/ofi/mtl_ofi.h     sep_peer_fiaddr = fi_rx_addr(endpoint->peer_fiaddr, ctxt_id, ompi_mtl_ofi.rx_ctx_bits);
ctxt_id           580 ompi/mca/mtl/ofi/mtl_ofi.h         MTL_OFI_RETRY_UNTIL_DONE(fi_tsenddata(ompi_mtl_ofi.ofi_ctxt[ctxt_id].tx_ep,
ctxt_id           589 ompi/mca/mtl/ofi/mtl_ofi.h         MTL_OFI_RETRY_UNTIL_DONE(fi_tsend(ompi_mtl_ofi.ofi_ctxt[ctxt_id].tx_ep,
ctxt_id           620 ompi/mca/mtl/ofi/mtl_ofi.h     int ompi_ret, ctxt_id = 0;
ctxt_id           628 ompi/mca/mtl/ofi/mtl_ofi.h     ctxt_id = ompi_mtl_ofi_map_comm_to_ctxt(ofi_req->comm->c_contextid);
ctxt_id           692 ompi/mca/mtl/ofi/mtl_ofi.h             ofi_req->remote_addr = fi_rx_addr(endpoint->peer_fiaddr, ctxt_id, ompi_mtl_ofi.rx_ctx_bits);
ctxt_id           708 ompi/mca/mtl/ofi/mtl_ofi.h         MTL_OFI_RETRY_UNTIL_DONE(fi_tsendmsg(ompi_mtl_ofi.ofi_ctxt[ctxt_id].tx_ep,
ctxt_id           758 ompi/mca/mtl/ofi/mtl_ofi.h     int ompi_ret = OMPI_SUCCESS, ctxt_id = 0;
ctxt_id           769 ompi/mca/mtl/ofi/mtl_ofi.h     ctxt_id = ompi_mtl_ofi_map_comm_to_ctxt(comm->c_contextid);
ctxt_id           770 ompi/mca/mtl/ofi/mtl_ofi.h     set_thread_context(ctxt_id);
ctxt_id           776 ompi/mca/mtl/ofi/mtl_ofi.h             remote_addr = fi_rx_addr(endpoint->peer_fiaddr, ctxt_id, ompi_mtl_ofi.rx_ctx_bits);
ctxt_id           807 ompi/mca/mtl/ofi/mtl_ofi.h     MTL_OFI_RETRY_UNTIL_DONE(fi_trecv(ompi_mtl_ofi.ofi_ctxt[ctxt_id].rx_ep,
ctxt_id           890 ompi/mca/mtl/ofi/mtl_ofi.h     int ompi_ret, ctxt_id = 0;
ctxt_id           895 ompi/mca/mtl/ofi/mtl_ofi.h     ctxt_id = ompi_mtl_ofi_map_comm_to_ctxt(comm->c_contextid);
ctxt_id           896 ompi/mca/mtl/ofi/mtl_ofi.h     set_thread_context(ctxt_id);
ctxt_id           929 ompi/mca/mtl/ofi/mtl_ofi.h     MTL_OFI_RETRY_UNTIL_DONE(fi_trecvmsg(ompi_mtl_ofi.ofi_ctxt[ctxt_id].rx_ep, &msg, msgflags), ret);
ctxt_id           986 ompi/mca/mtl/ofi/mtl_ofi.h     int ctxt_id = 0;
ctxt_id           988 ompi/mca/mtl/ofi/mtl_ofi.h     ctxt_id = ompi_mtl_ofi_map_comm_to_ctxt(comm->c_contextid);
ctxt_id           989 ompi/mca/mtl/ofi/mtl_ofi.h     set_thread_context(ctxt_id);
ctxt_id           996 ompi/mca/mtl/ofi/mtl_ofi.h             remote_proc = fi_rx_addr(endpoint->peer_fiaddr, ctxt_id, ompi_mtl_ofi.rx_ctx_bits);
ctxt_id          1031 ompi/mca/mtl/ofi/mtl_ofi.h     MTL_OFI_RETRY_UNTIL_DONE(fi_trecvmsg(ompi_mtl_ofi.ofi_ctxt[ctxt_id].rx_ep, &msg, msgflags), ret);
ctxt_id          1075 ompi/mca/mtl/ofi/mtl_ofi.h     int ctxt_id = 0;
ctxt_id          1077 ompi/mca/mtl/ofi/mtl_ofi.h     ctxt_id = ompi_mtl_ofi_map_comm_to_ctxt(comm->c_contextid);
ctxt_id          1078 ompi/mca/mtl/ofi/mtl_ofi.h     set_thread_context(ctxt_id);
ctxt_id          1093 ompi/mca/mtl/ofi/mtl_ofi.h             remote_proc = fi_rx_addr(endpoint->peer_fiaddr, ctxt_id, ompi_mtl_ofi.rx_ctx_bits);
ctxt_id          1129 ompi/mca/mtl/ofi/mtl_ofi.h     MTL_OFI_RETRY_UNTIL_DONE(fi_trecvmsg(ompi_mtl_ofi.ofi_ctxt[ctxt_id].rx_ep, &msg, msgflags), ret);
ctxt_id          1176 ompi/mca/mtl/ofi/mtl_ofi.h     int ret, ctxt_id = 0;
ctxt_id          1179 ompi/mca/mtl/ofi/mtl_ofi.h     ctxt_id = ompi_mtl_ofi_map_comm_to_ctxt(ofi_req->comm->c_contextid);
ctxt_id          1197 ompi/mca/mtl/ofi/mtl_ofi.h                 ret = fi_cancel((fid_t)ompi_mtl_ofi.ofi_ctxt[ctxt_id].rx_ep,
ctxt_id          1224 ompi/mca/mtl/ofi/mtl_ofi.h     int ctxt_id = ompi_mtl_ofi.total_ctxts_used;
ctxt_id          1250 ompi/mca/mtl/ofi/mtl_ofi.h             opal_show_help("help-mtl-ofi.txt", "SEP thread grouping ctxt limit", true, ctxt_id,
ctxt_id          1258 ompi/mca/mtl/ofi/mtl_ofi.h     ret = fi_tx_context(ompi_mtl_ofi.sep, ctxt_id, NULL, &ompi_mtl_ofi.ofi_ctxt[ctxt_id].tx_ep, NULL);
ctxt_id          1264 ompi/mca/mtl/ofi/mtl_ofi.h     ret = fi_rx_context(ompi_mtl_ofi.sep, ctxt_id, NULL, &ompi_mtl_ofi.ofi_ctxt[ctxt_id].rx_ep, NULL);
ctxt_id          1270 ompi/mca/mtl/ofi/mtl_ofi.h     ret = fi_cq_open(ompi_mtl_ofi.domain, &cq_attr, &ompi_mtl_ofi.ofi_ctxt[ctxt_id].cq, NULL);
ctxt_id          1277 ompi/mca/mtl/ofi/mtl_ofi.h     ret = fi_ep_bind(ompi_mtl_ofi.ofi_ctxt[ctxt_id].tx_ep, (fid_t)ompi_mtl_ofi.ofi_ctxt[ctxt_id].cq,
ctxt_id          1284 ompi/mca/mtl/ofi/mtl_ofi.h     ret = fi_ep_bind(ompi_mtl_ofi.ofi_ctxt[ctxt_id].rx_ep, (fid_t)ompi_mtl_ofi.ofi_ctxt[ctxt_id].cq,
ctxt_id          1292 ompi/mca/mtl/ofi/mtl_ofi.h     ret = fi_enable(ompi_mtl_ofi.ofi_ctxt[ctxt_id].tx_ep);
ctxt_id          1298 ompi/mca/mtl/ofi/mtl_ofi.h     ret = fi_enable(ompi_mtl_ofi.ofi_ctxt[ctxt_id].rx_ep);
ctxt_id          1306 ompi/mca/mtl/ofi/mtl_ofi.h     OBJ_CONSTRUCT(&ompi_mtl_ofi.ofi_ctxt[ctxt_id].context_lock, opal_mutex_t);
ctxt_id          1324 ompi/mca/mtl/ofi/mtl_ofi.h     if (ompi_mtl_ofi.ofi_ctxt[ctxt_id].tx_ep) {
ctxt_id          1325 ompi/mca/mtl/ofi/mtl_ofi.h         (void) fi_close((fid_t)ompi_mtl_ofi.ofi_ctxt[ctxt_id].tx_ep);
ctxt_id          1328 ompi/mca/mtl/ofi/mtl_ofi.h     if (ompi_mtl_ofi.ofi_ctxt[ctxt_id].rx_ep) {
ctxt_id          1329 ompi/mca/mtl/ofi/mtl_ofi.h         (void) fi_close((fid_t)ompi_mtl_ofi.ofi_ctxt[ctxt_id].rx_ep);
ctxt_id          1332 ompi/mca/mtl/ofi/mtl_ofi.h     if (ompi_mtl_ofi.ofi_ctxt[ctxt_id].cq) {
ctxt_id          1333 ompi/mca/mtl/ofi/mtl_ofi.h         (void) fi_close((fid_t)ompi_mtl_ofi.ofi_ctxt[ctxt_id].cq);
ctxt_id          1343 ompi/mca/mtl/ofi/mtl_ofi.h     int ret = OMPI_SUCCESS, ctxt_id = 0;
ctxt_id          1356 ompi/mca/mtl/ofi/mtl_ofi.h     ctxt_id = ompi_mtl_ofi.thread_grouping ?
ctxt_id          1363 ompi/mca/mtl/ofi/mtl_ofi.h     if ((ret = fi_close((fid_t)ompi_mtl_ofi.ofi_ctxt[ctxt_id].tx_ep))) {
ctxt_id          1367 ompi/mca/mtl/ofi/mtl_ofi.h     if ((ret = fi_close((fid_t)ompi_mtl_ofi.ofi_ctxt[ctxt_id].rx_ep))) {
ctxt_id          1371 ompi/mca/mtl/ofi/mtl_ofi.h     if ((ret = fi_close((fid_t)ompi_mtl_ofi.ofi_ctxt[ctxt_id].cq))) {
ctxt_id          1377 ompi/mca/mtl/ofi/mtl_ofi.h     OBJ_DESTRUCT(&ompi_mtl_ofi.ofi_ctxt[ctxt_id].context_lock);