context 1062 ompi/communicator/comm.c ompi_comm_idup_with_info_context_t *context; context 1078 ompi/communicator/comm.c context = OBJ_NEW(ompi_comm_idup_with_info_context_t); context 1079 ompi/communicator/comm.c if (NULL == context) { context 1084 ompi/communicator/comm.c context->comm = comm; context 1086 ompi/communicator/comm.c request->context = &context->super; context 1088 ompi/communicator/comm.c rc = ompi_comm_set_nb (&context->newcomp, /* new comm */ context 1107 ompi/communicator/comm.c ompi_communicator_t *newcomp = context->newcomp; context 1117 ompi/communicator/comm.c *newcomm = context->newcomp; context 1128 ompi/communicator/comm.c ompi_comm_idup_with_info_context_t *context = context 1129 ompi/communicator/comm.c (ompi_comm_idup_with_info_context_t *) request->context; context 1133 ompi/communicator/comm.c if (OMPI_COMM_IS_INTER(context->comm)){ context 1140 ompi/communicator/comm.c rc = ompi_comm_nextcid_nb (context->newcomp, context->comm, NULL, NULL, context 1144 ompi/communicator/comm.c OBJ_RELEASE(context->newcomp); context 1155 ompi/communicator/comm.c ompi_comm_idup_with_info_context_t *context = context 1156 ompi/communicator/comm.c (ompi_comm_idup_with_info_context_t *) request->context; context 1160 ompi/communicator/comm.c if (OMPI_COMM_IS_INTER(context->comm)){ context 1167 ompi/communicator/comm.c snprintf(context->newcomp->c_name, MPI_MAX_OBJECT_NAME, "MPI COMMUNICATOR %d DUP FROM %d", context 1168 ompi/communicator/comm.c context->newcomp->c_contextid, context->comm->c_contextid ); context 1171 ompi/communicator/comm.c rc = ompi_comm_activate_nb (&context->newcomp, context->comm, NULL, NULL, NULL, false, mode, subreq); context 1173 ompi/communicator/comm.c OBJ_RELEASE(context->newcomp); context 85 ompi/communicator/comm_cid.c static void mca_comm_cid_context_construct (ompi_comm_cid_context_t *context) context 87 ompi/communicator/comm_cid.c memset ((void *) ((intptr_t) context + sizeof (context->super)), 0, sizeof (*context) - sizeof (context->super)); context 90 ompi/communicator/comm_cid.c static void mca_comm_cid_context_destruct (ompi_comm_cid_context_t *context) context 92 ompi/communicator/comm_cid.c free (context->port_string); context 93 ompi/communicator/comm_cid.c free (context->pmix_tag); context 116 ompi/communicator/comm_cid.c static void ompi_comm_allreduce_context_construct (ompi_comm_allreduce_context_t *context) context 118 ompi/communicator/comm_cid.c memset ((void *) ((intptr_t) context + sizeof (context->super)), 0, sizeof (*context) - sizeof (context->super)); context 121 ompi/communicator/comm_cid.c static void ompi_comm_allreduce_context_destruct (ompi_comm_allreduce_context_t *context) context 123 ompi/communicator/comm_cid.c free (context->tmpbuf); context 172 ompi/communicator/comm_cid.c ompi_comm_cid_context_t *context; context 174 ompi/communicator/comm_cid.c context = OBJ_NEW(ompi_comm_cid_context_t); context 175 ompi/communicator/comm_cid.c if (OPAL_UNLIKELY(NULL == context)) { context 179 ompi/communicator/comm_cid.c context->newcomm = newcomm; context 180 ompi/communicator/comm_cid.c context->comm = comm; context 181 ompi/communicator/comm_cid.c context->bridgecomm = bridgecomm; context 182 ompi/communicator/comm_cid.c context->pml_tag = 0; context 188 ompi/communicator/comm_cid.c context->allreduce_fn = ompi_comm_allreduce_intra_nb; context 191 ompi/communicator/comm_cid.c context->allreduce_fn = ompi_comm_allreduce_inter_nb; context 194 ompi/communicator/comm_cid.c context->allreduce_fn = ompi_comm_allreduce_group_nb; context 195 ompi/communicator/comm_cid.c context->pml_tag = ((int *) arg0)[0]; context 198 ompi/communicator/comm_cid.c context->allreduce_fn = ompi_comm_allreduce_intra_pmix_nb; context 199 ompi/communicator/comm_cid.c context->local_leader = ((int *) arg0)[0]; context 201 ompi/communicator/comm_cid.c context->port_string = strdup ((char *) arg1); context 203 ompi/communicator/comm_cid.c context->pmix_tag = strdup ((char *) pmix_tag); context 206 ompi/communicator/comm_cid.c context->allreduce_fn = ompi_comm_allreduce_intra_bridge_nb; context 207 ompi/communicator/comm_cid.c context->local_leader = ((int *) arg0)[0]; context 208 ompi/communicator/comm_cid.c context->remote_leader = ((int *) arg1)[0]; context 211 ompi/communicator/comm_cid.c OBJ_RELEASE(context); context 215 ompi/communicator/comm_cid.c context->send_first = send_first; context 216 ompi/communicator/comm_cid.c context->iter = 0; context 217 ompi/communicator/comm_cid.c context->ok = 1; context 219 ompi/communicator/comm_cid.c return context; context 226 ompi/communicator/comm_cid.c ompi_comm_allreduce_context_t *context; context 228 ompi/communicator/comm_cid.c context = OBJ_NEW(ompi_comm_allreduce_context_t); context 229 ompi/communicator/comm_cid.c if (OPAL_UNLIKELY(NULL == context)) { context 233 ompi/communicator/comm_cid.c context->inbuf = inbuf; context 234 ompi/communicator/comm_cid.c context->outbuf = outbuf; context 235 ompi/communicator/comm_cid.c context->count = count; context 236 ompi/communicator/comm_cid.c context->op = op; context 237 ompi/communicator/comm_cid.c context->cid_context = cid_context; context 239 ompi/communicator/comm_cid.c return context; context 255 ompi/communicator/comm_cid.c ompi_comm_cid_context_t *context; context 258 ompi/communicator/comm_cid.c context = mca_comm_cid_context_alloc (newcomm, comm, bridgecomm, arg0, arg1, context 260 ompi/communicator/comm_cid.c if (NULL == context) { context 264 ompi/communicator/comm_cid.c context->start = ompi_mpi_communicators.lowest_free; context 268 ompi/communicator/comm_cid.c OBJ_RELEASE(context); context 272 ompi/communicator/comm_cid.c request->context = &context->super; context 304 ompi/communicator/comm_cid.c ompi_comm_cid_context_t *context = (ompi_comm_cid_context_t *) request->context; context 305 ompi/communicator/comm_cid.c int64_t my_id = ((int64_t) ompi_comm_get_cid (context->comm) << 32 | context->pml_tag); context 309 ompi/communicator/comm_cid.c int participate = (context->newcomm->c_local_group->grp_my_rank != MPI_UNDEFINED); context 327 ompi/communicator/comm_cid.c context->nextlocal_cid = mca_pml.pml_max_contextid; context 328 ompi/communicator/comm_cid.c for (unsigned int i = context->start ; i < mca_pml.pml_max_contextid ; ++i) { context 330 ompi/communicator/comm_cid.c context->comm); context 332 ompi/communicator/comm_cid.c context->nextlocal_cid = i; context 337 ompi/communicator/comm_cid.c context->nextlocal_cid = 0; context 340 ompi/communicator/comm_cid.c ret = context->allreduce_fn (&context->nextlocal_cid, &context->nextcid, 1, MPI_MAX, context 341 ompi/communicator/comm_cid.c context, &subreq); context 349 ompi/communicator/comm_cid.c if ( ((unsigned int) context->nextlocal_cid == mca_pml.pml_max_contextid) ) { context 360 ompi/communicator/comm_cid.c opal_pointer_array_test_and_set_item(&ompi_mpi_communicators, context->nextlocal_cid, NULL); context 370 ompi/communicator/comm_cid.c ompi_comm_cid_context_t *context = (ompi_comm_cid_context_t *) request->context; context 373 ompi/communicator/comm_cid.c int participate = (context->newcomm->c_local_group->grp_my_rank != MPI_UNDEFINED); context 377 ompi/communicator/comm_cid.c opal_pointer_array_set_item(&ompi_mpi_communicators, context->nextlocal_cid, NULL); context 387 ompi/communicator/comm_cid.c context->flag = 1; context 389 ompi/communicator/comm_cid.c context->flag = (context->nextcid == context->nextlocal_cid); context 390 ompi/communicator/comm_cid.c if ( participate && !context->flag) { context 391 ompi/communicator/comm_cid.c opal_pointer_array_set_item(&ompi_mpi_communicators, context->nextlocal_cid, NULL); context 393 ompi/communicator/comm_cid.c context->flag = opal_pointer_array_test_and_set_item (&ompi_mpi_communicators, context 394 ompi/communicator/comm_cid.c context->nextcid, context->comm); context 398 ompi/communicator/comm_cid.c ++context->iter; context 400 ompi/communicator/comm_cid.c ret = context->allreduce_fn (&context->flag, &context->rflag, 1, MPI_MIN, context, &subreq); context 404 ompi/communicator/comm_cid.c if (participate && context->flag ) { context 405 ompi/communicator/comm_cid.c opal_pointer_array_test_and_set_item(&ompi_mpi_communicators, context->nextlocal_cid, NULL); context 416 ompi/communicator/comm_cid.c ompi_comm_cid_context_t *context = (ompi_comm_cid_context_t *) request->context; context 417 ompi/communicator/comm_cid.c int participate = (context->newcomm->c_local_group->grp_my_rank != MPI_UNDEFINED); context 421 ompi/communicator/comm_cid.c opal_pointer_array_set_item(&ompi_mpi_communicators, context->nextcid, NULL); context 430 ompi/communicator/comm_cid.c if (0 != context->rflag) { context 436 ompi/communicator/comm_cid.c context->nextlocal_cid = mca_pml.pml_max_contextid; context 437 ompi/communicator/comm_cid.c for (unsigned int i = context->start ; i < mca_pml.pml_max_contextid ; ++i) { context 440 ompi/communicator/comm_cid.c context->comm); context 442 ompi/communicator/comm_cid.c context->nextlocal_cid = i; context 446 ompi/communicator/comm_cid.c context->nextcid = context->nextlocal_cid; context 450 ompi/communicator/comm_cid.c context->newcomm->c_contextid = context->nextcid; context 451 ompi/communicator/comm_cid.c opal_pointer_array_set_item (&ompi_mpi_communicators, context->nextcid, context->newcomm); context 461 ompi/communicator/comm_cid.c if (participate && (0 != context->flag)) { context 463 ompi/communicator/comm_cid.c opal_pointer_array_set_item (&ompi_mpi_communicators, context->nextcid, NULL); context 464 ompi/communicator/comm_cid.c context->start = context->nextcid + 1; /* that's where we can start the next round */ context 467 ompi/communicator/comm_cid.c ++context->iter; context 500 ompi/communicator/comm_cid.c ompi_comm_cid_context_t *context; context 505 ompi/communicator/comm_cid.c context = mca_comm_cid_context_alloc (*newcomm, comm, bridgecomm, arg0, arg1, "activate", context 507 ompi/communicator/comm_cid.c if (NULL == context) { context 512 ompi/communicator/comm_cid.c context->newcommp = newcomm; context 516 ompi/communicator/comm_cid.c OBJ_RELEASE(context); context 520 ompi/communicator/comm_cid.c request->context = &context->super; context 526 ompi/communicator/comm_cid.c OBJ_RELEASE(context); context 536 ompi/communicator/comm_cid.c ret = context->allreduce_fn (&context->ok, &context->ok, 1, MPI_MIN, context, context 572 ompi/communicator/comm_cid.c ompi_comm_cid_context_t *context = (ompi_comm_cid_context_t *) request->context; context 599 ompi/communicator/comm_cid.c if (MPI_UNDEFINED == (context->newcomm)->c_local_group->grp_my_rank) { context 605 ompi/communicator/comm_cid.c if (OMPI_SUCCESS != (ret = mca_coll_base_comm_select(context->newcomm))) { context 606 ompi/communicator/comm_cid.c OBJ_RELEASE(context->newcomm); context 607 ompi/communicator/comm_cid.c *context->newcommp = MPI_COMM_NULL; context 628 ompi/communicator/comm_cid.c if (OMPI_COMM_IS_INTER(context->newcomm)) { context 629 ompi/communicator/comm_cid.c if (OMPI_COMM_CID_IS_LOWER(context->newcomm, context->comm)) { context 630 ompi/communicator/comm_cid.c OMPI_COMM_SET_EXTRA_RETAIN (context->newcomm); context 631 ompi/communicator/comm_cid.c OBJ_RETAIN (context->newcomm); context 643 ompi/communicator/comm_cid.c ompi_comm_cid_context_t *context, ompi_request_t **req) context 645 ompi/communicator/comm_cid.c ompi_communicator_t *comm = context->comm; context 662 ompi/communicator/comm_cid.c ompi_comm_allreduce_context_t *context; context 676 ompi/communicator/comm_cid.c context = ompi_comm_allreduce_context_alloc (inbuf, outbuf, count, op, cid_context); context 677 ompi/communicator/comm_cid.c if (OPAL_UNLIKELY(NULL == context)) { context 682 ompi/communicator/comm_cid.c request->context = &context->super; context 688 ompi/communicator/comm_cid.c context->tmpbuf = (int *) calloc (count, sizeof(int)); context 689 ompi/communicator/comm_cid.c if (OPAL_UNLIKELY (NULL == context->tmpbuf)) { context 697 ompi/communicator/comm_cid.c rc = intercomm->c_local_comm->c_coll->coll_ireduce (inbuf, context->tmpbuf, count, MPI_INT, op, 0, context 720 ompi/communicator/comm_cid.c ompi_comm_allreduce_context_t *context = (ompi_comm_allreduce_context_t *) request->context; context 721 ompi/communicator/comm_cid.c ompi_communicator_t *intercomm = context->cid_context->comm; context 727 ompi/communicator/comm_cid.c rc = MCA_PML_CALL(irecv (context->outbuf, context->count, MPI_INT, 0, OMPI_COMM_ALLREDUCE_TAG, context 733 ompi/communicator/comm_cid.c rc = MCA_PML_CALL(isend (context->tmpbuf, context->count, MPI_INT, 0, OMPI_COMM_ALLREDUCE_TAG, context 744 ompi/communicator/comm_cid.c ompi_comm_allreduce_context_t *context = (ompi_comm_allreduce_context_t *) request->context; context 746 ompi/communicator/comm_cid.c ompi_op_reduce (context->op, context->tmpbuf, context->outbuf, context->count, MPI_INT); context 754 ompi/communicator/comm_cid.c ompi_comm_allreduce_context_t *context = (ompi_comm_allreduce_context_t *) request->context; context 755 ompi/communicator/comm_cid.c ompi_communicator_t *comm = context->cid_context->comm->c_local_comm; context 760 ompi/communicator/comm_cid.c rc = comm->c_coll->coll_ibcast (context->outbuf, context->count, MPI_INT, 0, comm, context 771 ompi/communicator/comm_cid.c ompi_comm_allreduce_context_t *context = (ompi_comm_allreduce_context_t *) request->context; context 772 ompi/communicator/comm_cid.c ompi_communicator_t *comm = context->cid_context->comm; context 776 ompi/communicator/comm_cid.c rc = comm->c_coll->coll_ibcast (context->outbuf, context->count, MPI_INT, context 777 ompi/communicator/comm_cid.c context->cid_context->local_leader, comm, context 788 ompi/communicator/comm_cid.c ompi_comm_allreduce_context_t *context = (ompi_comm_allreduce_context_t *) request->context; context 791 ompi/communicator/comm_cid.c ompi_op_reduce (context->op, context->tmpbuf, context->outbuf, context->count, MPI_INT); context 799 ompi/communicator/comm_cid.c ompi_comm_allreduce_context_t *context = (ompi_comm_allreduce_context_t *) request->context; context 800 ompi/communicator/comm_cid.c ompi_communicator_t *bridgecomm = context->cid_context->bridgecomm; context 805 ompi/communicator/comm_cid.c rc = MCA_PML_CALL(irecv (context->outbuf, context->count, MPI_INT, context->cid_context->remote_leader, context 811 ompi/communicator/comm_cid.c rc = MCA_PML_CALL(isend (context->tmpbuf, context->count, MPI_INT, context->cid_context->remote_leader, context 827 ompi/communicator/comm_cid.c ompi_comm_allreduce_context_t *context; context 833 ompi/communicator/comm_cid.c context = ompi_comm_allreduce_context_alloc (inbuf, outbuf, count, op, cid_context); context 834 ompi/communicator/comm_cid.c if (OPAL_UNLIKELY(NULL == context)) { context 839 ompi/communicator/comm_cid.c context->tmpbuf = (int *) calloc (count, sizeof (int)); context 840 ompi/communicator/comm_cid.c if (OPAL_UNLIKELY(NULL == context->tmpbuf)) { context 841 ompi/communicator/comm_cid.c OBJ_RELEASE(context); context 848 ompi/communicator/comm_cid.c OBJ_RELEASE(context); context 852 ompi/communicator/comm_cid.c request->context = &context->super; context 855 ompi/communicator/comm_cid.c memcpy (context->tmpbuf, inbuf, count * sizeof (int)); context 859 ompi/communicator/comm_cid.c rc = comm->c_coll->coll_ireduce (inbuf, context->tmpbuf, count, MPI_INT, op, context 891 ompi/communicator/comm_cid.c ompi_comm_allreduce_context_t *context = (ompi_comm_allreduce_context_t *) request->context; context 892 ompi/communicator/comm_cid.c ompi_comm_cid_context_t *cid_context = context->cid_context; context 893 ompi/communicator/comm_cid.c int32_t size_count = context->count; context 904 ompi/communicator/comm_cid.c if (OPAL_SUCCESS != (rc = opal_dss.pack(&sbuf, context->tmpbuf, (int32_t)context->count, OPAL_INT))) { context 966 ompi/communicator/comm_cid.c rc = opal_dss.unpack (&sbuf, context->outbuf, &size_count, OPAL_INT); context 972 ompi/communicator/comm_cid.c ompi_op_reduce (context->op, context->tmpbuf, context->outbuf, size_count, MPI_INT); context 983 ompi/communicator/comm_cid.c ompi_comm_allreduce_context_t *context; context 989 ompi/communicator/comm_cid.c context = ompi_comm_allreduce_context_alloc (inbuf, outbuf, count, op, cid_context); context 990 ompi/communicator/comm_cid.c if (OPAL_UNLIKELY(NULL == context)) { context 995 ompi/communicator/comm_cid.c context->tmpbuf = (int *) calloc (count, sizeof(int)); context 996 ompi/communicator/comm_cid.c if (OPAL_UNLIKELY(NULL == context->tmpbuf)) { context 997 ompi/communicator/comm_cid.c OBJ_RELEASE(context); context 1004 ompi/communicator/comm_cid.c OBJ_RELEASE(context); context 1008 ompi/communicator/comm_cid.c request->context = &context->super; context 1011 ompi/communicator/comm_cid.c rc = comm->c_coll->coll_ireduce (inbuf, context->tmpbuf, count, MPI_INT, op, context 1043 ompi/communicator/comm_cid.c ompi_comm_allreduce_context_t *context = (ompi_comm_allreduce_context_t *) request->context; context 1044 ompi/communicator/comm_cid.c ompi_comm_cid_context_t *cid_context = context->cid_context; context 1050 ompi/communicator/comm_cid.c if (MPI_PROC_NULL != context->peers_comm[i + 1]) { context 1051 ompi/communicator/comm_cid.c rc = MCA_PML_CALL(isend(context->outbuf, context->count, MPI_INT, context->peers_comm[i+1], context 1065 ompi/communicator/comm_cid.c ompi_comm_allreduce_context_t *context = (ompi_comm_allreduce_context_t *) request->context; context 1066 ompi/communicator/comm_cid.c ompi_comm_cid_context_t *cid_context = context->cid_context; context 1067 ompi/communicator/comm_cid.c int *tmp = context->tmpbuf; context 1072 ompi/communicator/comm_cid.c if (MPI_PROC_NULL != context->peers_comm[i + 1]) { context 1073 ompi/communicator/comm_cid.c ompi_op_reduce (context->op, tmp, context->outbuf, context->count, MPI_INT); context 1074 ompi/communicator/comm_cid.c tmp += context->count; context 1078 ompi/communicator/comm_cid.c if (MPI_PROC_NULL != context->peers_comm[0]) { context 1080 ompi/communicator/comm_cid.c rc = MCA_PML_CALL(isend(context->outbuf, context->count, MPI_INT, context->peers_comm[0], context 1087 ompi/communicator/comm_cid.c rc = MCA_PML_CALL(irecv(context->outbuf, context->count, MPI_INT, context->peers_comm[0], context 1109 ompi/communicator/comm_cid.c ompi_comm_allreduce_context_t *context; context 1113 ompi/communicator/comm_cid.c context = ompi_comm_allreduce_context_alloc (inbuf, outbuf, count, op, cid_context); context 1114 ompi/communicator/comm_cid.c if (NULL == context) { context 1118 ompi/communicator/comm_cid.c tmp = context->tmpbuf = calloc (sizeof (int), count * 3); context 1119 ompi/communicator/comm_cid.c if (NULL == context->tmpbuf) { context 1120 ompi/communicator/comm_cid.c OBJ_RELEASE(context); context 1126 ompi/communicator/comm_cid.c OBJ_RELEASE(context); context 1130 ompi/communicator/comm_cid.c request->context = &context->super; context 1138 ompi/communicator/comm_cid.c ompi_group_translate_ranks (group, 3, peers_group, comm->c_local_group, context->peers_comm); context 1144 ompi/communicator/comm_cid.c if (MPI_PROC_NULL != context->peers_comm[i + 1]) { context 1145 ompi/communicator/comm_cid.c int rc = MCA_PML_CALL(irecv(tmp, count, MPI_INT, context->peers_comm[i + 1], context 233 ompi/communicator/comm_request.c request->context = NULL; context 270 ompi/communicator/comm_request.c if (request->context) { context 271 ompi/communicator/comm_request.c OBJ_RELEASE (request->context); context 272 ompi/communicator/comm_request.c request->context = NULL; context 24 ompi/communicator/comm_request.h opal_object_t *context; context 705 ompi/mca/mtl/ofi/mtl_ofi.h tagged_msg.context = NULL; context 926 ompi/mca/mtl/ofi/mtl_ofi.h msg.context = (void *)&ofi_req->ctx; context 1022 ompi/mca/mtl/ofi/mtl_ofi.h msg.context = (void *)&ofi_req.ctx; context 1119 ompi/mca/mtl/ofi/mtl_ofi.h msg.context = (void *)&ofi_req->ctx; context 436 ompi/mca/mtl/psm/mtl_psm.c mtl_psm_request = (mca_mtl_psm_request_t*) psm_status.context; context 428 ompi/mca/mtl/psm2/mtl_psm2.c mtl_psm2_request = (mca_mtl_psm2_request_t*) psm2_status.context; context 57 ompi/mca/osc/rdma/osc_rdma_accumulate.c static void *ompi_osc_rdma_event_put (int fd, int flags, void *context) context 59 ompi/mca/osc/rdma/osc_rdma_accumulate.c ompi_osc_rdma_event_t *event = (ompi_osc_rdma_event_t *) context; context 679 ompi/mca/osc/rdma/osc_rdma_accumulate.c void *context, void *data, int status) context 681 ompi/mca/osc/rdma/osc_rdma_accumulate.c bool *complete = (bool *) context; context 84 ompi/mca/osc/rdma/osc_rdma_active_target.c void *context, void *data, int status) context 86 ompi/mca/osc/rdma/osc_rdma_active_target.c ompi_osc_rdma_pending_op_t *pending_op = (ompi_osc_rdma_pending_op_t *) context; context 51 ompi/mca/osc/rdma/osc_rdma_comm.c void *context, void *data, int status) context 54 ompi/mca/osc/rdma/osc_rdma_comm.c ((bool *) context)[0] = true; context 383 ompi/mca/osc/rdma/osc_rdma_comm.c void *context, void *data, int status) context 385 ompi/mca/osc/rdma/osc_rdma_comm.c ompi_osc_rdma_sync_t *sync = (ompi_osc_rdma_sync_t *) context; context 390 ompi/mca/osc/rdma/osc_rdma_comm.c if ((intptr_t) context & 0x1) { context 391 ompi/mca/osc/rdma/osc_rdma_comm.c ompi_osc_rdma_request_t *request = request = (ompi_osc_rdma_request_t *) ((intptr_t) context & ~1); context 412 ompi/mca/osc/rdma/osc_rdma_comm.c void *context, void *data, int status) context 414 ompi/mca/osc/rdma/osc_rdma_comm.c ompi_osc_rdma_module_t *module = (ompi_osc_rdma_module_t *) context; context 419 ompi/mca/osc/rdma/osc_rdma_comm.c if ((intptr_t) context & 0x1) { context 420 ompi/mca/osc/rdma/osc_rdma_comm.c ompi_osc_rdma_request_t *request = request = (ompi_osc_rdma_request_t *) ((intptr_t) context & ~1); context 440 ompi/mca/osc/rdma/osc_rdma_comm.c mca_btl_base_rdma_completion_fn_t cb, void *context, void *cbdata) { context 453 ompi/mca/osc/rdma/osc_rdma_comm.c cb, context, cbdata); context 533 ompi/mca/osc/rdma/osc_rdma_comm.c void *context, void *data, int status) context 535 ompi/mca/osc/rdma/osc_rdma_comm.c ompi_osc_rdma_request_t *request = (ompi_osc_rdma_request_t *) context; context 34 ompi/mca/osc/rdma/osc_rdma_lock.h void *context, void *data, int status); context 377 ompi/mca/pml/ob1/pml_ob1_recvreq.c void *context, void *cbdata, int status) context 379 ompi/mca/pml/ob1/pml_ob1_recvreq.c mca_bml_base_btl_t *bml_btl = (mca_bml_base_btl_t *) context; context 1136 ompi/mca/pml/ob1/pml_ob1_sendreq.c void *context, void *cbdata, int status) context 1140 ompi/mca/pml/ob1/pml_ob1_sendreq.c mca_bml_base_btl_t *bml_btl = (mca_bml_base_btl_t *) context; context 18 ompi/mca/pml/ucx/pml_ucx_datatype.c static void* pml_ucx_generic_datatype_start_pack(void *context, const void *buffer, context 21 ompi/mca/pml/ucx/pml_ucx_datatype.c ompi_datatype_t *datatype = context; context 34 ompi/mca/pml/ucx/pml_ucx_datatype.c static void* pml_ucx_generic_datatype_start_unpack(void *context, void *buffer, context 37 ompi/mca/pml/ucx/pml_ucx_datatype.c ompi_datatype_t *datatype = context; context 447 ompi/mca/pml/yalla/pml_yalla.c 0, mxm_sreq->base.context); context 83 ompi/mca/pml/yalla/pml_yalla_datatype.c size_t offset, void *context) context 85 ompi/mca/pml/yalla/pml_yalla_datatype.c mca_pml_yalla_base_request_t *req = context; context 90 ompi/mca/pml/yalla/pml_yalla_datatype.c size_t offset, void *context) context 92 ompi/mca/pml/yalla/pml_yalla_datatype.c mca_pml_yalla_convertor_t *convertor = context; context 97 ompi/mca/pml/yalla/pml_yalla_datatype.c size_t offset, void *context) context 99 ompi/mca/pml/yalla/pml_yalla_datatype.c mca_pml_yalla_base_request_t *req = context; context 104 ompi/mca/pml/yalla/pml_yalla_datatype.c size_t offset, void *context) context 106 ompi/mca/pml/yalla/pml_yalla_datatype.c mca_pml_yalla_convertor_t *convertor = context; context 125 ompi/mca/pml/yalla/pml_yalla_datatype.c mxm_req->context = convertor; context 143 ompi/mca/pml/yalla/pml_yalla_datatype.c mxm_req->context = convertor; context 124 ompi/mca/pml/yalla/pml_yalla_request.c mxm_req_base->context = NULL; context 159 ompi/mca/pml/yalla/pml_yalla_request.c static void mca_pml_yalla_send_completion_cb(void *context) context 161 ompi/mca/pml/yalla/pml_yalla_request.c mca_pml_yalla_send_request_t* sreq = context; context 185 ompi/mca/pml/yalla/pml_yalla_request.c static void mca_pml_yalla_bsend_completion_cb(void *context) context 187 ompi/mca/pml/yalla/pml_yalla_request.c mca_pml_yalla_bsend_request_t *bsreq = context; context 196 ompi/mca/pml/yalla/pml_yalla_request.c static void mca_pml_yalla_recv_completion_cb(void *context) context 198 ompi/mca/pml/yalla/pml_yalla_request.c mca_pml_yalla_recv_request_t* rreq = context; context 222 ompi/mca/pml/yalla/pml_yalla_request.c sreq->mxm.base.context = sreq; context 234 ompi/mca/pml/yalla/pml_yalla_request.c bsreq->mxm.base.context = bsreq; context 244 ompi/mca/pml/yalla/pml_yalla_request.c rreq->mxm.base.context = rreq; context 126 ompi/mca/pml/yalla/pml_yalla_request.h mca_pml_yalla_convertor_free((mca_pml_yalla_convertor_t*)((_req)->context)); \ context 81 opal/mca/allocator/basic/allocator_basic.c void *context) context 94 opal/mca/allocator/basic/allocator_basic.c module->super.alc_context = context; context 33 opal/mca/allocator/bucket/allocator_bucket.c void *context); context 67 opal/mca/allocator/bucket/allocator_bucket.c void *context) context 88 opal/mca/allocator/bucket/allocator_bucket.c allocator->super.alc_context = context; context 404 opal/mca/btl/btl.h void *context, context 353 opal/mca/btl/ofi/btl_ofi.h int mca_btl_ofi_context_progress(mca_btl_ofi_context_t *context); context 357 opal/mca/btl/ofi/btl_ofi.h int mca_btl_ofi_post_recvs(mca_btl_base_module_t* module, mca_btl_ofi_context_t *context, int count); context 361 opal/mca/btl/ofi/btl_ofi.h static inline bool mca_btl_ofi_context_trylock (mca_btl_ofi_context_t *context) context 363 opal/mca/btl/ofi/btl_ofi.h return (context->lock || OPAL_ATOMIC_SWAP_32(&context->lock, 1)); context 366 opal/mca/btl/ofi/btl_ofi.h static inline void mca_btl_ofi_context_lock(mca_btl_ofi_context_t *context) context 368 opal/mca/btl/ofi/btl_ofi.h while (mca_btl_ofi_context_trylock(context)); context 371 opal/mca/btl/ofi/btl_ofi.h static inline void mca_btl_ofi_context_unlock(mca_btl_ofi_context_t *context) context 374 opal/mca/btl/ofi/btl_ofi.h context->lock = 0; context 620 opal/mca/btl/ofi/btl_ofi_component.c mca_btl_ofi_context_t *context; context 626 opal/mca/btl/ofi/btl_ofi_component.c context = get_ofi_context(module); context 628 opal/mca/btl/ofi/btl_ofi_component.c if (mca_btl_ofi_context_trylock(context)) { context 629 opal/mca/btl/ofi/btl_ofi_component.c events += mca_btl_ofi_context_progress(context); context 630 opal/mca/btl/ofi/btl_ofi_component.c mca_btl_ofi_context_unlock(context); context 637 opal/mca/btl/ofi/btl_ofi_component.c context = get_ofi_context_rr(module); context 639 opal/mca/btl/ofi/btl_ofi_component.c if (mca_btl_ofi_context_trylock(context)) { context 640 opal/mca/btl/ofi/btl_ofi_component.c events += mca_btl_ofi_context_progress(context); context 641 opal/mca/btl/ofi/btl_ofi_component.c mca_btl_ofi_context_unlock(context); context 20 opal/mca/btl/ofi/btl_ofi_context.c int init_context_freelists(mca_btl_ofi_context_t *context) context 23 opal/mca/btl/ofi/btl_ofi_context.c OBJ_CONSTRUCT(&context->rdma_comp_list, opal_free_list_t); context 24 opal/mca/btl/ofi/btl_ofi_context.c rc = opal_free_list_init(&context->rdma_comp_list, context 44 opal/mca/btl/ofi/btl_ofi_context.c OBJ_CONSTRUCT(&context->frag_comp_list, opal_free_list_t); context 45 opal/mca/btl/ofi/btl_ofi_context.c rc = opal_free_list_init(&context->frag_comp_list, context 65 opal/mca/btl/ofi/btl_ofi_context.c OBJ_CONSTRUCT(&context->frag_list, opal_free_list_t); context 66 opal/mca/btl/ofi/btl_ofi_context.c rc = opal_free_list_init(&context->frag_list, context 105 opal/mca/btl/ofi/btl_ofi_context.c mca_btl_ofi_context_t *context; context 107 opal/mca/btl/ofi/btl_ofi_context.c context = (mca_btl_ofi_context_t*) calloc(1, sizeof(*context)); context 108 opal/mca/btl/ofi/btl_ofi_context.c if (NULL == context) { context 123 opal/mca/btl/ofi/btl_ofi_context.c rc = fi_cq_open(domain, &cq_attr, &context->cq, NULL); context 141 opal/mca/btl/ofi/btl_ofi_context.c rc = fi_ep_bind(ep, (fid_t)context->cq, cq_flags); context 150 opal/mca/btl/ofi/btl_ofi_context.c rc = init_context_freelists(context); context 155 opal/mca/btl/ofi/btl_ofi_context.c context->tx_ctx = ep; context 156 opal/mca/btl/ofi/btl_ofi_context.c context->rx_ctx = ep; context 157 opal/mca/btl/ofi/btl_ofi_context.c context->context_id = 0; context 159 opal/mca/btl/ofi/btl_ofi_context.c return context; context 162 opal/mca/btl/ofi/btl_ofi_context.c mca_btl_ofi_context_finalize(context, false); context 311 opal/mca/btl/ofi/btl_ofi_context.c void mca_btl_ofi_context_finalize(mca_btl_ofi_context_t *context, bool scalable_ep) { context 315 opal/mca/btl/ofi/btl_ofi_context.c if (NULL != context->tx_ctx) { context 316 opal/mca/btl/ofi/btl_ofi_context.c fi_close(&context->tx_ctx->fid); context 319 opal/mca/btl/ofi/btl_ofi_context.c if (NULL != context->rx_ctx) { context 320 opal/mca/btl/ofi/btl_ofi_context.c fi_close(&context->rx_ctx->fid); context 324 opal/mca/btl/ofi/btl_ofi_context.c if( NULL != context->cq) { context 325 opal/mca/btl/ofi/btl_ofi_context.c fi_close(&context->cq->fid); context 329 opal/mca/btl/ofi/btl_ofi_context.c OBJ_DESTRUCT(&context->rdma_comp_list); context 332 opal/mca/btl/ofi/btl_ofi_context.c OBJ_DESTRUCT(&context->frag_comp_list); context 333 opal/mca/btl/ofi/btl_ofi_context.c OBJ_DESTRUCT(&context->frag_list); context 370 opal/mca/btl/ofi/btl_ofi_context.c int mca_btl_ofi_context_progress(mca_btl_ofi_context_t *context) { context 383 opal/mca/btl/ofi/btl_ofi_context.c ret = fi_cq_read(context->cq, &cq_entry, mca_btl_ofi_component.num_cqe_read); context 417 opal/mca/btl/ofi/btl_ofi_context.c context, frag_comp->frag); context 436 opal/mca/btl/ofi/btl_ofi_context.c ret = fi_cq_readerr(context->cq, &cqerr, 0); context 54 opal/mca/btl/ofi/btl_ofi_endpoint.h int init_context_freelists(mca_btl_ofi_context_t *context); context 69 opal/mca/btl/ofi/btl_ofi_endpoint.h void mca_btl_ofi_context_finalize(mca_btl_ofi_context_t *context, bool scalable_ep); context 45 opal/mca/btl/ofi/btl_ofi_frag.c mca_btl_ofi_context_t *context, context 51 opal/mca/btl/ofi/btl_ofi_frag.c comp = (mca_btl_ofi_frag_completion_t*) opal_free_list_get(&context->frag_comp_list); context 53 opal/mca/btl/ofi/btl_ofi_frag.c comp->base.my_context = context; context 54 opal/mca/btl/ofi/btl_ofi_frag.c comp->base.my_list = &context->frag_comp_list; context 71 opal/mca/btl/ofi/btl_ofi_frag.c mca_btl_ofi_context_t *context = get_ofi_context(ofi_btl); context 73 opal/mca/btl/ofi/btl_ofi_frag.c frag = mca_btl_ofi_frag_alloc(ofi_btl, &context->frag_list, endpoint); context 102 opal/mca/btl/ofi/btl_ofi_frag.c mca_btl_ofi_context_t *context; context 114 opal/mca/btl/ofi/btl_ofi_frag.c context = get_ofi_context(ofi_btl); context 115 opal/mca/btl/ofi/btl_ofi_frag.c comp = mca_btl_ofi_frag_completion_alloc(btl, context, frag, context 120 opal/mca/btl/ofi/btl_ofi_frag.c rc = fi_send(context->tx_ctx, context 137 opal/mca/btl/ofi/btl_ofi_frag.c mca_btl_ofi_context_t *context, context 155 opal/mca/btl/ofi/btl_ofi_frag.c rc = mca_btl_ofi_post_recvs((mca_btl_base_module_t*) ofi_btl, context, 1); context 46 opal/mca/btl/ofi/btl_ofi_frag.h mca_btl_ofi_context_t *context, context 58 opal/mca/btl/ofi/btl_ofi_frag.h mca_btl_ofi_context_t *context, context 328 opal/mca/btl/ofi/btl_ofi_module.c mca_btl_ofi_context_t *context, context 348 opal/mca/btl/ofi/btl_ofi_module.c context, context 352 opal/mca/btl/ofi/btl_ofi_module.c rc = fi_recv (context->rx_ctx, &frag->hdr, MCA_BTL_OFI_RECV_SIZE, context 747 opal/mca/btl/portals4/btl_portals4_component.c frag->rdma_cb.context, context 62 opal/mca/btl/portals4/btl_portals4_frag.h void *context; context 73 opal/mca/btl/portals4/btl_portals4_rdma.c frag->rdma_cb.context = cbcontext; context 344 opal/mca/btl/tcp/btl_tcp.c frag->cb.func (btl, endpoint, frag->segments[0].seg_addr.pval, NULL, frag->cb.context, frag->cb.data, context 387 opal/mca/btl/tcp/btl_tcp.c frag->cb.context = cbcontext; context 454 opal/mca/btl/tcp/btl_tcp.c frag->cb.context = cbcontext; context 868 opal/mca/btl/tcp/btl_tcp_component.c static void mca_btl_tcp_component_event_async_handler(int fd, short unused, void *context) context 877 opal/mca/btl/tcp/btl_tcp_component.c opal_thread_t* current_thread = (opal_thread_t*)context; context 423 opal/mca/btl/tcp/btl_tcp_endpoint.c static void *mca_btl_tcp_endpoint_complete_accept(int fd, int flags, void *context) context 425 opal/mca/btl/tcp/btl_tcp_endpoint.c mca_btl_base_endpoint_t* btl_endpoint = (mca_btl_base_endpoint_t*)context; context 66 opal/mca/btl/tcp/btl_tcp_frag.h void *context; context 152 opal/mca/btl/uct/btl_uct_am.c mca_btl_uct_device_context_t *context, bool ready) context 163 opal/mca/btl/uct/btl_uct_am.c mca_btl_uct_device_context_t *context = frag->context; context 170 opal/mca/btl/uct/btl_uct_am.c (void) mca_btl_uct_endpoint_test_am (uct_btl, frag->endpoint, frag->context, &ep_handle); context 175 opal/mca/btl/uct/btl_uct_am.c if (!context->in_am_callback) { context 176 opal/mca/btl/uct/btl_uct_am.c mca_btl_uct_context_lock (context); context 179 opal/mca/btl/uct/btl_uct_am.c frag->comp.dev_context = context; context 184 opal/mca/btl/uct/btl_uct_am.c uct_worker_progress (context->uct_worker); context 185 opal/mca/btl/uct/btl_uct_am.c mca_btl_uct_context_unlock (context); context 195 opal/mca/btl/uct/btl_uct_am.c uct_worker_progress (context->uct_worker); context 196 opal/mca/btl/uct/btl_uct_am.c mca_btl_uct_context_unlock (context); context 205 opal/mca/btl/uct/btl_uct_am.c uct_worker_progress (context->uct_worker); context 206 opal/mca/btl/uct/btl_uct_am.c mca_btl_uct_context_unlock (context); context 214 opal/mca/btl/uct/btl_uct_am.c uct_worker_progress (context->uct_worker); context 215 opal/mca/btl/uct/btl_uct_am.c mca_btl_uct_context_unlock (context); context 217 opal/mca/btl/uct/btl_uct_am.c mca_btl_uct_device_handle_completions (context); context 225 opal/mca/btl/uct/btl_uct_am.c mca_btl_uct_append_pending_frag (uct_btl, frag, context, true); context 235 opal/mca/btl/uct/btl_uct_am.c mca_btl_uct_device_context_t *context = mca_btl_uct_module_get_am_context (uct_btl); context 245 opal/mca/btl/uct/btl_uct_am.c frag->context = context; context 247 opal/mca/btl/uct/btl_uct_am.c rc = mca_btl_uct_endpoint_check_am (uct_btl, endpoint, context, &ep_handle); context 251 opal/mca/btl/uct/btl_uct_am.c if (OPAL_SUCCESS != mca_btl_uct_endpoint_test_am (uct_btl, endpoint, context, &ep_handle)) { context 252 opal/mca/btl/uct/btl_uct_am.c mca_btl_uct_append_pending_frag (uct_btl, frag, context, false); context 293 opal/mca/btl/uct/btl_uct_am.c mca_btl_uct_device_context_t *context = mca_btl_uct_module_get_am_context (uct_btl); context 302 opal/mca/btl/uct/btl_uct_am.c rc = mca_btl_uct_endpoint_check_am (uct_btl, endpoint, context, &ep_handle); context 303 opal/mca/btl/uct/btl_uct_am.c if (OPAL_UNLIKELY(OPAL_SUCCESS != rc || msg_size > mca_btl_uct_max_sendi (uct_btl, context->context_id))) { context 313 opal/mca/btl/uct/btl_uct_am.c mca_btl_uct_context_lock (context); context 316 opal/mca/btl/uct/btl_uct_am.c } else if (msg_size < (size_t) MCA_BTL_UCT_TL_ATTR(uct_btl->am_tl, context->context_id).cap.am.max_short) { context 332 opal/mca/btl/uct/btl_uct_am.c mca_btl_uct_context_unlock (context); context 33 opal/mca/btl/uct/btl_uct_amo.c mca_btl_uct_device_context_t *context = mca_btl_uct_module_get_rdma_context (uct_btl); context 53 opal/mca/btl/uct/btl_uct_amo.c comp = mca_btl_uct_uct_completion_alloc (uct_btl, endpoint, local_address, local_handle, context, context 60 opal/mca/btl/uct/btl_uct_amo.c rc = mca_btl_uct_get_rkey (uct_btl, context, endpoint, remote_handle, &rkey, &ep_handle); context 66 opal/mca/btl/uct/btl_uct_amo.c mca_btl_uct_context_lock (context); context 97 opal/mca/btl/uct/btl_uct_amo.c (void) uct_worker_progress (context->uct_worker); context 99 opal/mca/btl/uct/btl_uct_amo.c mca_btl_uct_context_unlock (context); context 101 opal/mca/btl/uct/btl_uct_amo.c mca_btl_uct_device_handle_completions (context); context 139 opal/mca/btl/uct/btl_uct_amo.c mca_btl_uct_device_context_t *context = mca_btl_uct_module_get_rdma_context (uct_btl); context 147 opal/mca/btl/uct/btl_uct_amo.c comp = mca_btl_uct_uct_completion_alloc (uct_btl, endpoint, local_address, local_handle, context, context 154 opal/mca/btl/uct/btl_uct_amo.c rc = mca_btl_uct_get_rkey (uct_btl, context, endpoint, remote_handle, &rkey, &ep_handle); context 160 opal/mca/btl/uct/btl_uct_amo.c mca_btl_uct_context_lock (context); context 171 opal/mca/btl/uct/btl_uct_amo.c (void) uct_worker_progress (context->uct_worker); context 173 opal/mca/btl/uct/btl_uct_amo.c mca_btl_uct_context_unlock (context); context 175 opal/mca/btl/uct/btl_uct_amo.c mca_btl_uct_device_handle_completions (context); context 36 opal/mca/btl/uct/btl_uct_device_context.h void mca_btl_uct_context_destroy (mca_btl_uct_device_context_t *context); context 38 opal/mca/btl/uct/btl_uct_device_context.h static inline bool mca_btl_uct_context_trylock (mca_btl_uct_device_context_t *context) context 40 opal/mca/btl/uct/btl_uct_device_context.h return OPAL_THREAD_TRYLOCK(&context->mutex); context 43 opal/mca/btl/uct/btl_uct_device_context.h static inline void mca_btl_uct_context_lock (mca_btl_uct_device_context_t *context) context 45 opal/mca/btl/uct/btl_uct_device_context.h OPAL_THREAD_LOCK (&context->mutex); context 48 opal/mca/btl/uct/btl_uct_device_context.h static inline void mca_btl_uct_context_unlock (mca_btl_uct_device_context_t *context) context 50 opal/mca/btl/uct/btl_uct_device_context.h OPAL_THREAD_UNLOCK (&context->mutex); context 53 opal/mca/btl/uct/btl_uct_device_context.h #define MCA_BTL_UCT_CONTEXT_SERIALIZE(context,code) \ context 55 opal/mca/btl/uct/btl_uct_device_context.h mca_btl_uct_context_lock (context); \ context 57 opal/mca/btl/uct/btl_uct_device_context.h mca_btl_uct_context_unlock(context); \ context 89 opal/mca/btl/uct/btl_uct_device_context.h mca_btl_uct_device_context_t *context = tl->uct_dev_contexts[context_id]; context 91 opal/mca/btl/uct/btl_uct_device_context.h if (OPAL_UNLIKELY(NULL == context)) { context 93 opal/mca/btl/uct/btl_uct_device_context.h context = tl->uct_dev_contexts[context_id]; context 94 opal/mca/btl/uct/btl_uct_device_context.h if (OPAL_UNLIKELY(NULL == context)) { context 95 opal/mca/btl/uct/btl_uct_device_context.h context = tl->uct_dev_contexts[context_id] = mca_btl_uct_context_create (module, tl, context_id, true); context 100 opal/mca/btl/uct/btl_uct_device_context.h return context; context 142 opal/mca/btl/uct/btl_uct_device_context.h static inline int mca_btl_uct_context_progress (mca_btl_uct_device_context_t *context) context 146 opal/mca/btl/uct/btl_uct_device_context.h if (!context->uct_worker) { context 150 opal/mca/btl/uct/btl_uct_device_context.h if (!mca_btl_uct_context_trylock (context)) { context 151 opal/mca/btl/uct/btl_uct_device_context.h ret = uct_worker_progress (context->uct_worker); context 152 opal/mca/btl/uct/btl_uct_device_context.h mca_btl_uct_context_unlock (context); context 154 opal/mca/btl/uct/btl_uct_device_context.h mca_btl_uct_device_handle_completions (context); context 35 opal/mca/btl/uct/btl_uct_endpoint.h mca_btl_uct_device_context_t *context, uct_ep_h *ep_handle) context 38 opal/mca/btl/uct/btl_uct_endpoint.h int ep_index = context->context_id; context 62 opal/mca/btl/uct/btl_uct_endpoint.h mca_btl_uct_device_context_t *context, uct_ep_h *ep_handle, context 65 opal/mca/btl/uct/btl_uct_endpoint.h int ep_index = context->context_id; context 81 opal/mca/btl/uct/btl_uct_endpoint.h mca_btl_uct_device_context_t *context, uct_ep_h *ep_handle) context 84 opal/mca/btl/uct/btl_uct_endpoint.h return mca_btl_uct_endpoint_check (module, endpoint, context, ep_handle, module->rdma_tl->tl_index); context 88 opal/mca/btl/uct/btl_uct_endpoint.h mca_btl_uct_device_context_t *context, uct_ep_h *ep_handle) context 91 opal/mca/btl/uct/btl_uct_endpoint.h return mca_btl_uct_endpoint_check (module, endpoint, context, ep_handle, module->am_tl->tl_index); context 74 opal/mca/btl/uct/btl_uct_rdma.c mca_btl_uct_device_context_t *context = mca_btl_uct_module_get_rdma_context (uct_btl); context 84 opal/mca/btl/uct/btl_uct_rdma.c comp = mca_btl_uct_uct_completion_alloc (uct_btl, endpoint, local_address, local_handle, context, context 92 opal/mca/btl/uct/btl_uct_rdma.c rc = mca_btl_uct_get_rkey (uct_btl, context, endpoint, remote_handle, &rkey, &ep_handle); context 99 opal/mca/btl/uct/btl_uct_rdma.c mca_btl_uct_context_lock (context); context 101 opal/mca/btl/uct/btl_uct_rdma.c if (size <= MCA_BTL_UCT_TL_ATTR(uct_btl->rdma_tl, context->context_id).cap.get.max_bcopy) { context 111 opal/mca/btl/uct/btl_uct_rdma.c if (!context->in_am_callback) { context 112 opal/mca/btl/uct/btl_uct_rdma.c (void) uct_worker_progress (context->uct_worker); context 115 opal/mca/btl/uct/btl_uct_rdma.c mca_btl_uct_context_unlock (context); context 117 opal/mca/btl/uct/btl_uct_rdma.c if (!context->in_am_callback) { context 118 opal/mca/btl/uct/btl_uct_rdma.c mca_btl_uct_device_handle_completions (context); context 161 opal/mca/btl/uct/btl_uct_rdma.c mca_btl_uct_device_context_t *context = mca_btl_uct_module_get_rdma_context (uct_btl); context 173 opal/mca/btl/uct/btl_uct_rdma.c comp = mca_btl_uct_uct_completion_alloc (uct_btl, endpoint, local_address, local_handle, context, context 180 opal/mca/btl/uct/btl_uct_rdma.c rc = mca_btl_uct_get_rkey (uct_btl, context, endpoint, remote_handle, &rkey, &ep_handle); context 186 opal/mca/btl/uct/btl_uct_rdma.c mca_btl_uct_context_lock (context); context 190 opal/mca/btl/uct/btl_uct_rdma.c use_short = size <= MCA_BTL_UCT_TL_ATTR(uct_btl->rdma_tl, context->context_id).cap.put.max_short; context 211 opal/mca/btl/uct/btl_uct_rdma.c if (UCS_ERR_NO_RESOURCE != ucs_status || context->in_am_callback) { context 212 opal/mca/btl/uct/btl_uct_rdma.c if (!context->in_am_callback) { context 213 opal/mca/btl/uct/btl_uct_rdma.c (void) uct_worker_progress (context->uct_worker); context 220 opal/mca/btl/uct/btl_uct_rdma.c while (!uct_worker_progress (context->uct_worker)); context 223 opal/mca/btl/uct/btl_uct_rdma.c mca_btl_uct_context_unlock (context); context 225 opal/mca/btl/uct/btl_uct_rdma.c mca_btl_uct_device_handle_completions (context); context 255 opal/mca/btl/uct/btl_uct_rdma.c mca_btl_uct_device_context_t *context = uct_btl->rdma_tl->uct_dev_contexts[i]; context 257 opal/mca/btl/uct/btl_uct_rdma.c if (NULL == context) { context 261 opal/mca/btl/uct/btl_uct_rdma.c mca_btl_uct_context_lock (context); context 265 opal/mca/btl/uct/btl_uct_rdma.c uct_worker_progress (context->uct_worker); context 267 opal/mca/btl/uct/btl_uct_rdma.c if (NULL != endpoint && endpoint->uct_eps[context->context_id][tl_index].uct_ep) { context 268 opal/mca/btl/uct/btl_uct_rdma.c ucs_status = uct_ep_flush (endpoint->uct_eps[context->context_id][tl_index].uct_ep, 0, NULL); context 270 opal/mca/btl/uct/btl_uct_rdma.c ucs_status = uct_iface_flush (context->uct_iface, 0, NULL); context 274 opal/mca/btl/uct/btl_uct_rdma.c mca_btl_uct_context_unlock (context); context 275 opal/mca/btl/uct/btl_uct_rdma.c mca_btl_uct_device_handle_completions (context); context 285 opal/mca/btl/uct/btl_uct_rdma.c mca_btl_uct_device_context_t *context = uct_btl->rdma_tl->uct_dev_contexts[context_id]; context 290 opal/mca/btl/uct/btl_uct_rdma.c if (NULL == context) { context 294 opal/mca/btl/uct/btl_uct_rdma.c mca_btl_uct_context_lock (context); context 299 opal/mca/btl/uct/btl_uct_rdma.c uct_worker_progress (context->uct_worker); context 300 opal/mca/btl/uct/btl_uct_rdma.c ucs_status = uct_iface_flush (context->uct_iface, 0, NULL); context 303 opal/mca/btl/uct/btl_uct_rdma.c mca_btl_uct_context_unlock (context); context 305 opal/mca/btl/uct/btl_uct_rdma.c mca_btl_uct_device_handle_completions (context); context 44 opal/mca/btl/uct/btl_uct_rdma.h mca_btl_uct_device_context_t *context, context 53 opal/mca/btl/uct/btl_uct_rdma.h rc = mca_btl_uct_endpoint_check_rdma (module, endpoint, context, ep_handle); context 232 opal/mca/btl/uct/btl_uct_tl.c if (frag->context->context_id == req->context_id && endpoint == frag->endpoint) { context 259 opal/mca/btl/uct/btl_uct_tl.c static void mca_btl_uct_context_enable_progress (mca_btl_uct_device_context_t *context) context 261 opal/mca/btl/uct/btl_uct_tl.c if (!context->progress_enabled) { context 263 opal/mca/btl/uct/btl_uct_tl.c uct_iface_progress_enable (context->uct_iface, UCT_PROGRESS_THREAD_SAFE | UCT_PROGRESS_SEND | context 266 opal/mca/btl/uct/btl_uct_tl.c uct_iface_progress_enable (context->uct_iface, UCT_PROGRESS_SEND | UCT_PROGRESS_RECV); context 268 opal/mca/btl/uct/btl_uct_tl.c context->progress_enabled = true; context 286 opal/mca/btl/uct/btl_uct_tl.c mca_btl_uct_device_context_t *context; context 290 opal/mca/btl/uct/btl_uct_tl.c context = calloc (1, sizeof (*context)); context 291 opal/mca/btl/uct/btl_uct_tl.c if (OPAL_UNLIKELY(NULL == context)) { context 295 opal/mca/btl/uct/btl_uct_tl.c context->context_id = context_id; context 296 opal/mca/btl/uct/btl_uct_tl.c context->uct_btl = module; context 297 opal/mca/btl/uct/btl_uct_tl.c OBJ_CONSTRUCT(&context->completion_fifo, opal_fifo_t); context 298 opal/mca/btl/uct/btl_uct_tl.c OBJ_CONSTRUCT(&context->mutex, opal_recursive_mutex_t); context 299 opal/mca/btl/uct/btl_uct_tl.c OBJ_CONSTRUCT(&context->rdma_completions, opal_free_list_t); context 301 opal/mca/btl/uct/btl_uct_tl.c rc = opal_free_list_init (&context->rdma_completions, sizeof (mca_btl_uct_uct_completion_t), context 306 opal/mca/btl/uct/btl_uct_tl.c mca_btl_uct_context_destroy (context); context 314 opal/mca/btl/uct/btl_uct_tl.c ucs_status = uct_worker_create (module->ucs_async, UCS_THREAD_MODE_SINGLE, &context->uct_worker); context 317 opal/mca/btl/uct/btl_uct_tl.c mca_btl_uct_context_destroy (context); context 321 opal/mca/btl/uct/btl_uct_tl.c ucs_status = uct_iface_open (tl->uct_md->uct_md, context->uct_worker, &iface_params, context 322 opal/mca/btl/uct/btl_uct_tl.c tl->uct_tl_config, &context->uct_iface); context 325 opal/mca/btl/uct/btl_uct_tl.c mca_btl_uct_context_destroy (context); context 330 opal/mca/btl/uct/btl_uct_tl.c ucs_status = uct_iface_query (context->uct_iface, &context->uct_iface_attr); context 333 opal/mca/btl/uct/btl_uct_tl.c mca_btl_uct_context_destroy (context); context 339 opal/mca/btl/uct/btl_uct_tl.c uct_iface_set_am_handler (context->uct_iface, MCA_BTL_UCT_FRAG, mca_btl_uct_am_handler, context 340 opal/mca/btl/uct/btl_uct_tl.c context, MCA_BTL_UCT_CB_FLAG_SYNC); context 345 opal/mca/btl/uct/btl_uct_tl.c mca_btl_uct_context_enable_progress (context); context 348 opal/mca/btl/uct/btl_uct_tl.c return context; context 351 opal/mca/btl/uct/btl_uct_tl.c void mca_btl_uct_context_destroy (mca_btl_uct_device_context_t *context) context 353 opal/mca/btl/uct/btl_uct_tl.c if (context->uct_iface) { context 354 opal/mca/btl/uct/btl_uct_tl.c uct_iface_close (context->uct_iface); context 355 opal/mca/btl/uct/btl_uct_tl.c context->uct_iface = NULL; context 358 opal/mca/btl/uct/btl_uct_tl.c if (context->uct_worker) { context 359 opal/mca/btl/uct/btl_uct_tl.c uct_worker_destroy (context->uct_worker); context 360 opal/mca/btl/uct/btl_uct_tl.c context->uct_worker = NULL; context 363 opal/mca/btl/uct/btl_uct_tl.c OBJ_DESTRUCT(&context->completion_fifo); context 364 opal/mca/btl/uct/btl_uct_tl.c OBJ_DESTRUCT(&context->rdma_completions); context 365 opal/mca/btl/uct/btl_uct_tl.c free (context); context 248 opal/mca/btl/uct/btl_uct_types.h mca_btl_uct_device_context_t *context; context 79 opal/mca/btl/ugni/btl_ugni_get.c void *context, void *cbdata, int status) context 82 opal/mca/btl/ugni/btl_ugni_get.c mca_btl_ugni_base_frag_t *frag = (mca_btl_ugni_base_frag_t *) context; context 473 opal/mca/btl/usnic/btl_usnic_cagent.c static void agent_thread_receive_ping(int fd, short flags, void *context) context 476 opal/mca/btl/usnic/btl_usnic_cagent.c (agent_udp_port_listener_t *) context; context 710 opal/mca/btl/usnic/btl_usnic_cagent.c static void agent_thread_send_ping(int fd, short flags, void *context) context 712 opal/mca/btl/usnic/btl_usnic_cagent.c agent_ping_t *ap = (agent_ping_t*) context; context 947 opal/mca/btl/usnic/btl_usnic_cagent.c static void agent_thread_ipc_receive(int fd, short flags, void *context) context 950 opal/mca/btl/usnic/btl_usnic_cagent.c agent_ipc_listener_t *ipc_listener = (agent_ipc_listener_t*) context; context 989 opal/mca/btl/usnic/btl_usnic_cagent.c static void agent_thread_accept(int fd, short flags, void *context) context 1064 opal/mca/btl/usnic/btl_usnic_cagent.c static void agent_thread_finalize(int fd, short flags, void *context) context 1067 opal/mca/btl/usnic/btl_usnic_cagent.c free(context); context 276 opal/mca/btl/usnic/btl_usnic_module.c opal_btl_usnic_addr_context_t *context; context 285 opal/mca/btl/usnic/btl_usnic_module.c context = entry.context; context 286 opal/mca/btl/usnic/btl_usnic_module.c free(context); context 305 opal/mca/btl/usnic/btl_usnic_module.c context = err_entry.context; context 324 opal/mca/btl/usnic/btl_usnic_module.c if (endpoints[i] == context->endpoint) { context 326 opal/mca/btl/usnic/btl_usnic_module.c context->endpoint); context 327 opal/mca/btl/usnic/btl_usnic_module.c OBJ_RELEASE(context->endpoint); context 677 opal/mca/btl/usnic/btl_usnic_proc.c opal_btl_usnic_addr_context_t *context; context 680 opal/mca/btl/usnic/btl_usnic_proc.c context = calloc(1, sizeof(*context)); context 681 opal/mca/btl/usnic/btl_usnic_proc.c context->endpoint = endpoint; context 682 opal/mca/btl/usnic/btl_usnic_proc.c context->channel_id = channel; context 698 opal/mca/btl/usnic/btl_usnic_proc.c &endpoint->endpoint_remote_addrs[channel], 0, context); context 708 opal/mca/btl/usnic/btl_usnic_proc.c free(context); context 35 opal/mca/btl/usnic/btl_usnic_recv.h msg.context = rseg; context 24 opal/mca/btl/vader/btl_vader_atomic.c void *context = frag->rdma.context; context 31 opal/mca/btl/vader/btl_vader_atomic.c cbfunc (btl, endpoint, local_address, NULL, context, cbdata, status); context 59 opal/mca/btl/vader/btl_vader_atomic.c void *context = frag->rdma.context; context 70 opal/mca/btl/vader/btl_vader_atomic.c cbfunc (btl, endpoint, local_address, NULL, context, cbdata, status); context 95 opal/mca/btl/vader/btl_vader_frag.h void *context; context 174 opal/mca/btl/vader/btl_vader_frag.h frag->rdma.context = cbcontext; context 166 opal/mca/btl/vader/btl_vader_get.c void *context = frag->rdma.context; context 179 opal/mca/btl/vader/btl_vader_get.c cbfunc (btl, endpoint, local_address, NULL, context, cbdata, status); context 143 opal/mca/btl/vader/btl_vader_put.c void *context = frag->rdma.context; context 150 opal/mca/btl/vader/btl_vader_put.c cbfunc (btl, endpoint, local_address, NULL, context, cbdata, status); context 101 opal/mca/dl/base/base.h void *context), context 102 opal/mca/dl/base/base.h void *context); context 60 opal/mca/dl/base/dl_base_fns.c int (*cb_func)(const char *filename, void *context), context 61 opal/mca/dl/base/dl_base_fns.c void *context) context 64 opal/mca/dl/base/dl_base_fns.c return opal_dl->foreachfile(search_path, cb_func, context); context 141 opal/mca/dl/dl.h int (*cb_func)(const char *filename, void *context), context 142 opal/mca/dl/dl.h void *context); context 92 opal/mca/event/libevent2022/libevent/bufferevent_filter.c void *context; context 197 opal/mca/event/libevent2022/libevent/bufferevent_filter.c bufev_f->context = ctx; context 220 opal/mca/event/libevent2022/libevent/bufferevent_filter.c bevf->free_context(bevf->context); context 299 opal/mca/event/libevent2022/libevent/bufferevent_filter.c bev->input, limit, state, bevf->context); context 356 opal/mca/event/libevent2022/libevent/bufferevent_filter.c bevf->context); context 100 opal/mca/pmix/pmix4x/pmix/src/mca/pdl/base/base.h int (*cb_func)(const char *filename, void *context), context 101 opal/mca/pmix/pmix4x/pmix/src/mca/pdl/base/base.h void *context); context 62 opal/mca/pmix/pmix4x/pmix/src/mca/pdl/base/pdl_base_fns.c int (*cb_func)(const char *filename, void *context), context 63 opal/mca/pmix/pmix4x/pmix/src/mca/pdl/base/pdl_base_fns.c void *context) context 66 opal/mca/pmix/pmix4x/pmix/src/mca/pdl/base/pdl_base_fns.c return pmix_pdl->foreachfile(search_path, cb_func, context); context 141 opal/mca/pmix/pmix4x/pmix/src/mca/pdl/pdl.h int (*cb_func)(const char *filename, void *context), context 142 opal/mca/pmix/pmix4x/pmix/src/mca/pdl/pdl.h void *context); context 160 orte/mca/odls/base/odls_private.h ORTE_DECLSPEC int orte_odls_base_preload_files_app_context(orte_app_context_t* context); context 259 orte/mca/rtc/hwloc/rtc_hwloc.c orte_app_context_t *context; context 279 orte/mca/rtc/hwloc/rtc_hwloc.c context = (orte_app_context_t*)opal_pointer_array_get_item(jobdat->apps, child->app_idx); context 291 orte/mca/rtc/hwloc/rtc_hwloc.c orte_process_info.nodename, context->app, context 315 orte/mca/rtc/hwloc/rtc_hwloc.c orte_process_info.nodename, context->app, msg, context 320 orte/mca/rtc/hwloc/rtc_hwloc.c orte_process_info.nodename, context->app, msg, context 352 orte/mca/rtc/hwloc/rtc_hwloc.c context->app, msg, context 357 orte/mca/rtc/hwloc/rtc_hwloc.c orte_process_info.nodename, context->app, msg, context 381 orte/mca/rtc/hwloc/rtc_hwloc.c orte_process_info.nodename, context->app, msg, context 386 orte/mca/rtc/hwloc/rtc_hwloc.c orte_process_info.nodename, context->app, msg, context 441 orte/mca/rtc/hwloc/rtc_hwloc.c orte_process_info.nodename, context->app, msg, context 446 orte/mca/rtc/hwloc/rtc_hwloc.c orte_process_info.nodename, context->app, msg, context 74 orte/mca/schizo/base/base.h orte_app_context_t *context); context 112 orte/mca/schizo/base/schizo_base_stubs.c orte_app_context_t *context) context 119 orte/mca/schizo/base/schizo_base_stubs.c rc = mod->module->setup_fork(jdata, context); context 62 orte/mca/schizo/ompi/schizo_ompi.c orte_app_context_t *context); context 85 orte/mca/schizo/schizo.h orte_app_context_t *context); context 56 orte/util/context_fns.c int orte_util_check_context_cwd(orte_app_context_t *context, context 65 orte/util/context_fns.c if (want_chdir && 0 != chdir(context->cwd)) { context 74 orte/util/context_fns.c if (orte_get_attribute(&context->attributes, ORTE_APP_USER_CWD, context 96 orte/util/context_fns.c if (NULL != context->cwd) free(context->cwd); context 97 orte/util/context_fns.c context->cwd = strdup(tmp); context 109 orte/util/context_fns.c int orte_util_check_context_app(orte_app_context_t *context, char **env) context 133 orte/util/context_fns.c tmp = opal_basename(context->app); context 134 orte/util/context_fns.c if (strlen(tmp) == strlen(context->app)) { context 138 orte/util/context_fns.c tmp = opal_path_findv(context->app, X_OK, env, context->cwd); context 142 orte/util/context_fns.c free(context->app); context 143 orte/util/context_fns.c context->app = tmp; context 146 orte/util/context_fns.c if (0 != access(context->app, X_OK)) { context 33 orte/util/context_fns.h ORTE_DECLSPEC int orte_util_check_context_app(orte_app_context_t *context, context 36 orte/util/context_fns.h ORTE_DECLSPEC int orte_util_check_context_cwd(orte_app_context_t *context, context 335 orte/util/show_help.c static void show_accumulated_duplicates(int fd, short event, void *context) context 55 oshmem/mca/memheap/base/memheap_base_select.c memheap_context_t *context; context 67 oshmem/mca/memheap/base/memheap_base_select.c context = _memheap_create(); context 68 oshmem/mca/memheap/base/memheap_base_select.c if (NULL == context) { context 72 oshmem/mca/memheap/base/memheap_base_select.c if (OSHMEM_SUCCESS != best_component->memheap_init(context)) { context 81 oshmem/mca/memheap/base/memheap_base_select.c best_module->memheap_size = context->user_size; context 103 oshmem/mca/memheap/base/memheap_base_select.c static memheap_context_t context; context 145 oshmem/mca/memheap/base/memheap_base_select.c context.user_size = user_size; context 146 oshmem/mca/memheap/base/memheap_base_select.c context.private_size = MEMHEAP_BASE_PRIVATE_SIZE; context 147 oshmem/mca/memheap/base/memheap_base_select.c context.user_base_addr = context 150 oshmem/mca/memheap/base/memheap_base_select.c context.private_base_addr = context 152 oshmem/mca/memheap/base/memheap_base_select.c + context.user_size); context 155 oshmem/mca/memheap/base/memheap_base_select.c return ((OSHMEM_SUCCESS == rc) ? &context : NULL ); context 183 oshmem/mca/memheap/buddy/memheap_buddy.c int mca_memheap_buddy_module_init(memheap_context_t *context) context 185 oshmem/mca/memheap/buddy/memheap_buddy.c if (!context || !context->user_size || !context->private_size) { context 192 oshmem/mca/memheap/buddy/memheap_buddy.c memheap_buddy.heap.max_order = memheap_log2(context->user_size); context 194 oshmem/mca/memheap/buddy/memheap_buddy.c memheap_buddy.private_heap.max_order = memheap_log2(context->private_size); context 197 oshmem/mca/memheap/buddy/memheap_buddy.c if (context->user_size != (1ULL << memheap_buddy.heap.max_order)) { context 200 oshmem/mca/memheap/buddy/memheap_buddy.c (unsigned long long)context->user_size, 1ULL << memheap_buddy.heap.max_order); context 203 oshmem/mca/memheap/buddy/memheap_buddy.c assert(context->private_size == (1ULL << memheap_buddy.private_heap.max_order)); context 205 oshmem/mca/memheap/buddy/memheap_buddy.c memheap_buddy.heap.symmetric_heap = context->user_base_addr; context 206 oshmem/mca/memheap/buddy/memheap_buddy.c memheap_buddy.private_heap.symmetric_heap = context->private_base_addr; context 212 oshmem/mca/memheap/buddy/memheap_buddy.c (unsigned long long)(context->user_size + context->private_size)); context 47 oshmem/mca/memheap/ptmalloc/memheap_ptmalloc.c int mca_memheap_ptmalloc_module_init(memheap_context_t *context) context 49 oshmem/mca/memheap/ptmalloc/memheap_ptmalloc.c if (!context || !context->user_size || !context->private_size) { context 55 oshmem/mca/memheap/ptmalloc/memheap_ptmalloc.c memheap_ptmalloc.base = context->user_base_addr; context 57 oshmem/mca/memheap/ptmalloc/memheap_ptmalloc.c memheap_ptmalloc.max_size = context->user_size + context->private_size; context 58 oshmem/mca/memheap/ptmalloc/memheap_ptmalloc.c memheap_ptmalloc.max_alloc_size = context->user_size; context 62 oshmem/mca/memheap/ptmalloc/memheap_ptmalloc.c (unsigned long long)(context->user_size + context->private_size)); context 726 oshmem/mca/spml/ikrit/spml_ikrit.c get_req->mxm_req.base.context = get_req; context 760 oshmem/mca/spml/ikrit/spml_ikrit.c fence_req->mxm_req.base.context = fence_req; context 867 oshmem/mca/spml/ikrit/spml_ikrit.c put_req->mxm_req.base.context = put_req; context 934 oshmem/mca/spml/ikrit/spml_ikrit.c mxm_req.base.context = 0; context 442 oshmem/mca/spml/ucx/spml_ucx.c mca_sshmem_ucx_segment_context_t *ctx = mem_seg->context; context 121 oshmem/mca/sshmem/sshmem_types.h void *context; /* allocator can use this field to store context 162 oshmem/mca/sshmem/ucx/sshmem_ucx_module.c ds_buf->context = ctx; context 296 oshmem/mca/sshmem/ucx/sshmem_ucx_module.c mca_sshmem_ucx_segment_context_t *ctx = ds_buf->context; context 310 oshmem/mca/sshmem/ucx/sshmem_ucx_module.c ds_buf->context = NULL; context 354 oshmem/mca/sshmem/ucx/sshmem_ucx_module.c mca_sshmem_ucx_segment_context_t *ctx = s->context; context 402 oshmem/mca/sshmem/ucx/sshmem_ucx_module.c mca_sshmem_ucx_segment_context_t *ctx = s->context;