xfer 152 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event.h bool xfer); xfer 1281 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c bool xfer) xfer 1292 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (xfer) { xfer 239 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c static pmix_status_t _add_hdlr(pmix_rshift_caddy_t *cd, pmix_list_t *xfer) xfer 299 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c cd2->ninfo = pmix_list_get_size(xfer); xfer 303 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c PMIX_LIST_FOREACH(ixfer, xfer, pmix_info_caddy_t) { xfer 316 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c (need_register || 0 < pmix_list_get_size(xfer))) { xfer 469 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c pmix_list_t xfer; xfer 482 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c PMIX_CONSTRUCT(&xfer, pmix_list_t); xfer 532 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c pmix_list_append(&xfer, &ixfer->super); xfer 539 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c pmix_list_append(&xfer, &ixfer->super); xfer 544 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c pmix_list_append(&xfer, &ixfer->super); xfer 625 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c rc = _add_hdlr(cd, &xfer); xfer 626 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c PMIX_LIST_DESTRUCT(&xfer); xfer 718 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c rc = _add_hdlr(cd, &xfer); xfer 720 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c PMIX_LIST_DESTRUCT(&xfer); xfer 1796 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c pmix_buffer_t xfer; xfer 1852 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c PMIX_CONSTRUCT(&xfer, pmix_buffer_t); xfer 1853 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c PMIX_LOAD_BUFFER(pmix_globals.mypeer, &xfer, kv->value->data.bo.bytes, kv->value->data.bo.size); xfer 1855 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c rc = _store_data_for_rank(ds_ctx, elem, rank, &xfer); xfer 1857 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c PMIX_DESTRUCT(&xfer); xfer 2284 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c pmix_buffer_t xfer, *reply; xfer 2312 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_CONSTRUCT(&xfer, pmix_buffer_t); xfer 2354 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_LOAD_BUFFER(pmix_globals.mypeer, &xfer, scd->data, scd->ndata); xfer 2355 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_GDS_STORE_MODEX(rc, nptr->ns, &xfer, tracker); xfer 2394 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c xfer.base_ptr = NULL; xfer 2395 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c xfer.bytes_used = 0; xfer 2396 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_DESTRUCT(&xfer); xfer 688 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c pmix_buffer_t xfer; xfer 689 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c PMIX_CONSTRUCT(&xfer, pmix_buffer_t); xfer 690 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c PMIX_BFROPS_PACK(rc, cd->peer, &xfer, &pkt, 1, PMIX_BUFFER); xfer 695 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c PMIX_DESTRUCT(&xfer); xfer 699 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c PMIX_UNLOAD_BUFFER(&xfer, bo.bytes, bo.size); xfer 700 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c PMIX_DESTRUCT(&xfer); xfer 3708 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_buffer_t *reply, xfer; xfer 3760 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_CONSTRUCT(&xfer, pmix_buffer_t); xfer 3785 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_LOAD_BUFFER(pmix_globals.mypeer, &xfer, bo->bytes, bo->size); xfer 3786 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_GDS_STORE_MODEX(ret, nptr->ns, &xfer, trk); xfer 160 orte/mca/filem/raw/filem_raw_module.c static void xfer_complete(int status, orte_filem_raw_xfer_t *xfer) xfer 162 orte/mca/filem/raw/filem_raw_module.c orte_filem_raw_outbound_t *outbound = xfer->outbound; xfer 170 orte/mca/filem/raw/filem_raw_module.c opal_list_remove_item(&outbound->xfers, &xfer->super); xfer 172 orte/mca/filem/raw/filem_raw_module.c opal_list_append(&positioned_files, &xfer->super); xfer 192 orte/mca/filem/raw/filem_raw_module.c orte_filem_raw_xfer_t *xfer; xfer 223 orte/mca/filem/raw/filem_raw_module.c xfer = (orte_filem_raw_xfer_t*)itm; xfer 224 orte/mca/filem/raw/filem_raw_module.c if (0 == strcmp(file, xfer->file)) { xfer 227 orte/mca/filem/raw/filem_raw_module.c xfer->status = st; xfer 230 orte/mca/filem/raw/filem_raw_module.c xfer->nrecvd++; xfer 232 orte/mca/filem/raw/filem_raw_module.c if (xfer->nrecvd == orte_process_info.num_procs) { xfer 236 orte/mca/filem/raw/filem_raw_module.c file, xfer->status)); xfer 237 orte/mca/filem/raw/filem_raw_module.c xfer_complete(xfer->status, xfer); xfer 254 orte/mca/filem/raw/filem_raw_module.c orte_filem_raw_xfer_t *xfer, *xptr; xfer 497 orte/mca/filem/raw/filem_raw_module.c xfer = OBJ_NEW(orte_filem_raw_xfer_t); xfer 499 orte/mca/filem/raw/filem_raw_module.c xfer->src = strdup(fs->local_target); xfer 535 orte/mca/filem/raw/filem_raw_module.c xfer->file = strdup(cptr); xfer 536 orte/mca/filem/raw/filem_raw_module.c xfer->type = fs->target_flag; xfer 537 orte/mca/filem/raw/filem_raw_module.c xfer->app_idx = fs->app_idx; xfer 538 orte/mca/filem/raw/filem_raw_module.c xfer->outbound = outbound; xfer 539 orte/mca/filem/raw/filem_raw_module.c opal_list_append(&outbound->xfers, &xfer->super); xfer 540 orte/mca/filem/raw/filem_raw_module.c opal_event_set(orte_event_base, &xfer->ev, fd, OPAL_EV_READ, send_chunk, xfer); xfer 541 orte/mca/filem/raw/filem_raw_module.c opal_event_set_priority(&xfer->ev, ORTE_MSG_PRI); xfer 542 orte/mca/filem/raw/filem_raw_module.c xfer->pending = true; xfer 543 orte/mca/filem/raw/filem_raw_module.c ORTE_POST_OBJECT(xfer); xfer 544 orte/mca/filem/raw/filem_raw_module.c opal_event_add(&xfer->ev, 0); xfer 157 orte/mca/rml/base/rml_base_frame.c static void xfer_cons(orte_self_send_xfer_t *xfer) xfer 159 orte/mca/rml/base/rml_base_frame.c xfer->iov = NULL; xfer 160 orte/mca/rml/base/rml_base_frame.c xfer->cbfunc.iov = NULL; xfer 161 orte/mca/rml/base/rml_base_frame.c xfer->buffer = NULL; xfer 162 orte/mca/rml/base/rml_base_frame.c xfer->cbfunc.buffer = NULL; xfer 163 orte/mca/rml/base/rml_base_frame.c xfer->cbdata = NULL; xfer 41 orte/mca/rml/oob/rml_oob_send.c orte_self_send_xfer_t *xfer = (orte_self_send_xfer_t*)data; xfer 43 orte/mca/rml/oob/rml_oob_send.c ORTE_ACQUIRE_OBJECT(xfer); xfer 47 orte/mca/rml/oob/rml_oob_send.c ORTE_NAME_PRINT(ORTE_PROC_MY_NAME), xfer->tag)); xfer 52 orte/mca/rml/oob/rml_oob_send.c if (NULL != xfer->iov) { xfer 53 orte/mca/rml/oob/rml_oob_send.c if (NULL != xfer->cbfunc.iov) { xfer 55 orte/mca/rml/oob/rml_oob_send.c xfer->cbfunc.iov(ORTE_SUCCESS, ORTE_PROC_MY_NAME, xfer->iov, xfer->count, xfer 56 orte/mca/rml/oob/rml_oob_send.c xfer->tag, xfer->cbdata); xfer 58 orte/mca/rml/oob/rml_oob_send.c } else if (NULL != xfer->buffer) { xfer 59 orte/mca/rml/oob/rml_oob_send.c if (NULL != xfer->cbfunc.buffer) { xfer 61 orte/mca/rml/oob/rml_oob_send.c xfer->cbfunc.buffer(ORTE_SUCCESS, ORTE_PROC_MY_NAME, xfer->buffer, xfer 62 orte/mca/rml/oob/rml_oob_send.c xfer->tag, xfer->cbdata); xfer 70 orte/mca/rml/oob/rml_oob_send.c OBJ_RELEASE(xfer); xfer 83 orte/mca/rml/oob/rml_oob_send.c orte_self_send_xfer_t *xfer; xfer 128 orte/mca/rml/oob/rml_oob_send.c xfer = OBJ_NEW(orte_self_send_xfer_t); xfer 129 orte/mca/rml/oob/rml_oob_send.c xfer->iov = iov; xfer 130 orte/mca/rml/oob/rml_oob_send.c xfer->count = count; xfer 131 orte/mca/rml/oob/rml_oob_send.c xfer->cbfunc.iov = cbfunc; xfer 132 orte/mca/rml/oob/rml_oob_send.c xfer->tag = tag; xfer 133 orte/mca/rml/oob/rml_oob_send.c xfer->cbdata = cbdata; xfer 135 orte/mca/rml/oob/rml_oob_send.c ORTE_THREADSHIFT(xfer, orte_event_base, send_self_exe, ORTE_MSG_PRI); xfer 187 orte/mca/rml/oob/rml_oob_send.c orte_self_send_xfer_t *xfer; xfer 230 orte/mca/rml/oob/rml_oob_send.c xfer = OBJ_NEW(orte_self_send_xfer_t); xfer 231 orte/mca/rml/oob/rml_oob_send.c xfer->buffer = buffer; xfer 232 orte/mca/rml/oob/rml_oob_send.c xfer->cbfunc.buffer = cbfunc; xfer 233 orte/mca/rml/oob/rml_oob_send.c xfer->tag = tag; xfer 234 orte/mca/rml/oob/rml_oob_send.c xfer->cbdata = cbdata; xfer 236 orte/mca/rml/oob/rml_oob_send.c ORTE_THREADSHIFT(xfer, orte_event_base, send_self_exe, ORTE_MSG_PRI); xfer 457 orte/orted/pmix/pmix_server.c opal_buffer_t xfer; xfer 464 orte/orted/pmix/pmix_server.c OBJ_CONSTRUCT(&xfer, opal_buffer_t); xfer 465 orte/orted/pmix/pmix_server.c opal_dss.load(&xfer, (void*)data, sz); xfer 466 orte/orted/pmix/pmix_server.c opal_dss.copy_payload(&req->msg, &xfer); xfer 467 orte/orted/pmix/pmix_server.c xfer.base_ptr = NULL; // protect the incoming data xfer 468 orte/orted/pmix/pmix_server.c OBJ_DESTRUCT(&xfer); xfer 157 orte/orted/pmix/pmix_server_pub.c opal_buffer_t *xfer; xfer 179 orte/orted/pmix/pmix_server_pub.c xfer = OBJ_NEW(opal_buffer_t); xfer 181 orte/orted/pmix/pmix_server_pub.c if (OPAL_SUCCESS != (rc = opal_dss.pack(xfer, &req->room_num, 1, OPAL_INT))) { xfer 183 orte/orted/pmix/pmix_server_pub.c OBJ_RELEASE(xfer); xfer 186 orte/orted/pmix/pmix_server_pub.c opal_dss.copy_payload(xfer, &req->msg); xfer 208 orte/orted/pmix/pmix_server_pub.c rc = orte_rml.send_buffer_nb(target, xfer, xfer 108 orte/test/system/orte_dfs.c opal_buffer_t *buf, *xfer; xfer 239 orte/test/system/orte_dfs.c if (OPAL_SUCCESS != (rc = opal_dss.unpack(buf, &xfer, &cnt, OPAL_BUFFER))) { xfer 244 orte/test/system/orte_dfs.c if (OPAL_SUCCESS != (rc = opal_dss.unpack(xfer, &host, &cnt, OPAL_STRING))) { xfer 249 orte/test/system/orte_dfs.c if (OPAL_SUCCESS != (rc = opal_dss.unpack(xfer, &path, &cnt, OPAL_STRING))) { xfer 254 orte/test/system/orte_dfs.c if (OPAL_SUCCESS != (rc = opal_dss.unpack(xfer, &length, &cnt, OPAL_INT64))) { xfer 259 orte/test/system/orte_dfs.c if (OPAL_SUCCESS != (rc = opal_dss.unpack(xfer, &offset, &cnt, OPAL_INT64))) { xfer 264 orte/test/system/orte_dfs.c if (OPAL_SUCCESS != (rc = opal_dss.unpack(xfer, &partition, &cnt, OPAL_INT64))) { xfer 268 orte/test/system/orte_dfs.c OBJ_RELEASE(xfer);