cb 149 ompi/debuggers/ompi_mpihandles_dll.c int mpidbg_init_once(const mqs_basic_callbacks *cb) cb 151 ompi/debuggers/ompi_mpihandles_dll.c mqs_basic_entrypoints = cb; cb 176 ompi/debuggers/ompi_msgq_dll.c void mqs_setup_basic_callbacks (const mqs_basic_callbacks * cb) cb 178 ompi/debuggers/ompi_msgq_dll.c mqs_basic_entrypoints = cb; cb 582 ompi/debuggers/ompi_msgq_dll.c communicator_t * cb = *(communicator_t **)b; cb 584 ompi/debuggers/ompi_msgq_dll.c return cb->comm_info.unique_id - ca->comm_info.unique_id; cb 68 ompi/mca/io/romio321/romio/adio/common/iscontig.c int *ints, ni, na, nt, cb; cb 89 ompi/mca/io/romio321/romio/adio/common/iscontig.c MPI_Type_get_envelope(types[0], &ni, &na, &nt, &cb); cb 90 ompi/mca/io/romio321/romio/adio/common/iscontig.c if (cb != MPI_COMBINER_NAMED) MPI_Type_free(types); cb 1739 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c ompi_communicator_t *comm, ompi_request_complete_fn_t cb, void *ctx) cb 1756 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c request->req_complete_cb = cb; cb 1766 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c ompi_request_complete_fn_t cb, void *ctx) cb 1786 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.c (*request_out)->req_complete_cb = cb; cb 72 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.h ompi_communicator_t *comm, ompi_request_complete_fn_t cb, void *ctx); cb 96 ompi/mca/osc/pt2pt/osc_pt2pt_data_move.h ompi_request_complete_fn_t cb, void *ctx); cb 440 ompi/mca/osc/rdma/osc_rdma_comm.c mca_btl_base_rdma_completion_fn_t cb, void *context, void *cbdata) { cb 453 ompi/mca/osc/rdma/osc_rdma_comm.c cb, context, cbdata); cb 731 ompi/mca/pml/ucx/pml_ucx.c ucp_send_callback_t cb) cb 736 ompi/mca/pml/ucx/pml_ucx.c return ucp_tag_send_sync_nb(ep, buf, count, ucx_datatype, tag, cb); cb 738 ompi/mca/pml/ucx/pml_ucx.c return ucp_tag_send_nb(ep, buf, count, ucx_datatype, tag, cb); cb 784 ompi/mca/pml/ucx/pml_ucx.c ucp_send_callback_t cb) cb 790 ompi/mca/pml/ucx/pml_ucx.c tag, mode, cb); cb 446 ompi/mca/pml/yalla/pml_yalla.c mxm_sreq->base.data.stream.cb(bsreq->mxm.base.data.buffer.ptr, length, cb 48 ompi/mca/pml/yalla/pml_yalla_datatype.c mxm_req->data.stream.cb = stream_cb; cb 1024 ompi/mpi/java/c/mpi_MPI.c int *cb = (int*)calloc(length, sizeof(int)); cb 1027 ompi/mpi/java/c/mpi_MPI.c cb[i] = jb[i]; cb 1030 ompi/mpi/java/c/mpi_MPI.c *cptr = cb; cb 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, cb 385 opal/mca/btl/tcp/btl_tcp.c frag->cb.func = cbfunc; cb 386 opal/mca/btl/tcp/btl_tcp.c frag->cb.data = cbdata; cb 387 opal/mca/btl/tcp/btl_tcp.c frag->cb.context = cbcontext; cb 452 opal/mca/btl/tcp/btl_tcp.c frag->cb.func = cbfunc; cb 453 opal/mca/btl/tcp/btl_tcp.c frag->cb.data = cbdata; cb 454 opal/mca/btl/tcp/btl_tcp.c frag->cb.context = cbcontext; cb 67 opal/mca/btl/tcp/btl_tcp_frag.h } cb; cb 80 opal/mca/event/external/external.h #define opal_event_set(b, x, fd, fg, cb, arg) event_assign((x), (b), (fd), (fg), (event_callback_fn) (cb), (arg)) cb 82 opal/mca/event/external/external.h #define opal_event_assign(x, b, fd, fg, cb, arg) event_assign((x), (b), (fd), (fg), (event_callback_fn) (cb), (arg)) cb 90 opal/mca/event/external/external.h #define opal_event_new(b, fd, fg, cb, arg) event_new((b), (fd), (fg), (event_callback_fn) (cb), (arg)) cb 97 opal/mca/event/external/external.h #define opal_event_evtimer_new(b, cb, arg) opal_event_new((b), -1, 0, (cb), (arg)) cb 101 opal/mca/event/external/external.h #define opal_event_evtimer_set(b, x, cb, arg) event_assign((x), (b), -1, 0, (event_callback_fn) (cb), (arg)) cb 112 opal/mca/event/external/external.h #define opal_event_signal_set(b, x, fd, cb, arg) event_assign((x), (b), (fd), EV_SIGNAL|EV_PERSIST, (event_callback_fn) (cb), (arg)) cb 141 opal/mca/event/libevent2022/libevent/buffer.c static void evbuffer_deferred_callback(struct deferred_cb *cb, void *arg); cb 491 opal/mca/event/libevent2022/libevent/buffer.c cbent->cb.cb_obsolete(buffer, cb 494 opal/mca/event/libevent2022/libevent/buffer.c cbent->cb.cb_func(buffer, &info, cbent->cbarg); cb 520 opal/mca/event/libevent2022/libevent/buffer.c evbuffer_deferred_callback(struct deferred_cb *cb, void *arg) cb 2943 opal/mca/event/libevent2022/libevent/buffer.c evbuffer_setcb(struct evbuffer *buffer, evbuffer_cb cb, void *cbarg) cb 2950 opal/mca/event/libevent2022/libevent/buffer.c if (cb) { cb 2953 opal/mca/event/libevent2022/libevent/buffer.c ent->cb.cb_obsolete = cb; cb 2960 opal/mca/event/libevent2022/libevent/buffer.c evbuffer_add_cb(struct evbuffer *buffer, evbuffer_cb_func cb, void *cbarg) cb 2966 opal/mca/event/libevent2022/libevent/buffer.c e->cb.cb_func = cb; cb 2986 opal/mca/event/libevent2022/libevent/buffer.c evbuffer_remove_cb(struct evbuffer *buffer, evbuffer_cb_func cb, void *cbarg) cb 2992 opal/mca/event/libevent2022/libevent/buffer.c if (cb == cbent->cb.cb_func && cbarg == cbent->cbarg) { cb 3004 opal/mca/event/libevent2022/libevent/buffer.c struct evbuffer_cb_entry *cb, ev_uint32_t flags) cb 3009 opal/mca/event/libevent2022/libevent/buffer.c cb->flags |= flags; cb 3016 opal/mca/event/libevent2022/libevent/buffer.c struct evbuffer_cb_entry *cb, ev_uint32_t flags) cb 3021 opal/mca/event/libevent2022/libevent/buffer.c cb->flags &= ~flags; cb 3052 opal/mca/event/libevent2022/libevent/buffer.c evbuffer_cb_suspend(struct evbuffer *buffer, struct evbuffer_cb_entry *cb) cb 3054 opal/mca/event/libevent2022/libevent/buffer.c if (!(cb->flags & EVBUFFER_CB_SUSPENDED)) { cb 3055 opal/mca/event/libevent2022/libevent/buffer.c cb->size_before_suspend = evbuffer_get_length(buffer); cb 3056 opal/mca/event/libevent2022/libevent/buffer.c cb->flags |= EVBUFFER_CB_SUSPENDED; cb 3061 opal/mca/event/libevent2022/libevent/buffer.c evbuffer_cb_unsuspend(struct evbuffer *buffer, struct evbuffer_cb_entry *cb) cb 3063 opal/mca/event/libevent2022/libevent/buffer.c if ((cb->flags & EVBUFFER_CB_SUSPENDED)) { cb 3064 opal/mca/event/libevent2022/libevent/buffer.c unsigned call = (cb->flags & EVBUFFER_CB_CALL_ON_UNSUSPEND); cb 3065 opal/mca/event/libevent2022/libevent/buffer.c size_t sz = cb->size_before_suspend; cb 3066 opal/mca/event/libevent2022/libevent/buffer.c cb->flags &= ~(EVBUFFER_CB_SUSPENDED| cb 3068 opal/mca/event/libevent2022/libevent/buffer.c cb->size_before_suspend = 0; cb 3069 opal/mca/event/libevent2022/libevent/buffer.c if (call && (cb->flags & EVBUFFER_CB_ENABLED)) { cb 3070 opal/mca/event/libevent2022/libevent/buffer.c cb->cb(buffer, sz, evbuffer_get_length(buffer), cb->cbarg); cb 48 opal/mca/event/libevent2022/libevent/defer-internal.h deferred_cb_fn cb; cb 69 opal/mca/event/libevent2022/libevent/evbuffer-internal.h } cb; cb 774 opal/mca/event/libevent2022/libevent/evdns.c struct deferred_reply_callback *cb = cb 777 opal/mca/event/libevent2022/libevent/evdns.c switch (cb->request_type) { cb 779 opal/mca/event/libevent2022/libevent/evdns.c if (cb->have_reply) cb 780 opal/mca/event/libevent2022/libevent/evdns.c cb->user_callback(DNS_ERR_NONE, DNS_IPv4_A, cb 781 opal/mca/event/libevent2022/libevent/evdns.c cb->reply.data.a.addrcount, cb->ttl, cb 782 opal/mca/event/libevent2022/libevent/evdns.c cb->reply.data.a.addresses, cb 785 opal/mca/event/libevent2022/libevent/evdns.c cb->user_callback(cb->err, 0, 0, cb->ttl, NULL, user_pointer); cb 788 opal/mca/event/libevent2022/libevent/evdns.c if (cb->have_reply) { cb 789 opal/mca/event/libevent2022/libevent/evdns.c char *name = cb->reply.data.ptr.name; cb 790 opal/mca/event/libevent2022/libevent/evdns.c cb->user_callback(DNS_ERR_NONE, DNS_PTR, 1, cb->ttl, cb 793 opal/mca/event/libevent2022/libevent/evdns.c cb->user_callback(cb->err, 0, 0, cb->ttl, NULL, user_pointer); cb 797 opal/mca/event/libevent2022/libevent/evdns.c if (cb->have_reply) cb 798 opal/mca/event/libevent2022/libevent/evdns.c cb->user_callback(DNS_ERR_NONE, DNS_IPv6_AAAA, cb 799 opal/mca/event/libevent2022/libevent/evdns.c cb->reply.data.aaaa.addrcount, cb->ttl, cb 800 opal/mca/event/libevent2022/libevent/evdns.c cb->reply.data.aaaa.addresses, cb 803 opal/mca/event/libevent2022/libevent/evdns.c cb->user_callback(cb->err, 0, 0, cb->ttl, NULL, user_pointer); cb 809 opal/mca/event/libevent2022/libevent/evdns.c if (cb->handle && cb->handle->pending_cb) { cb 810 opal/mca/event/libevent2022/libevent/evdns.c mm_free(cb->handle); cb 813 opal/mca/event/libevent2022/libevent/evdns.c mm_free(cb); cb 1692 opal/mca/event/libevent2022/libevent/evdns.c evdns_add_server_port_with_base(struct event_base *base, evutil_socket_t socket, int flags, evdns_request_callback_fn_type cb, void *user_data) cb 1706 opal/mca/event/libevent2022/libevent/evdns.c port->user_callback = cb; cb 1723 opal/mca/event/libevent2022/libevent/evdns.c evdns_add_server_port(evutil_socket_t socket, int flags, evdns_request_callback_fn_type cb, void *user_data) cb 1725 opal/mca/event/libevent2022/libevent/evdns.c return evdns_add_server_port_with_base(NULL, socket, flags, cb, user_data); cb 4537 opal/mca/event/libevent2022/libevent/evdns.c evdns_getaddrinfo_cb cb, void *arg) cb 4552 opal/mca/event/libevent2022/libevent/evdns.c cb(EVUTIL_EAI_FAIL, NULL, arg); /* ??? better error? */ cb 4561 opal/mca/event/libevent2022/libevent/evdns.c cb(err, res, arg); cb 4581 opal/mca/event/libevent2022/libevent/evdns.c cb(err, res, arg); cb 4587 opal/mca/event/libevent2022/libevent/evdns.c cb(0, res, arg); cb 4596 opal/mca/event/libevent2022/libevent/evdns.c cb(EVUTIL_EAI_MEMORY, NULL, arg); cb 4604 opal/mca/event/libevent2022/libevent/evdns.c data->user_cb = cb; cb 4653 opal/mca/event/libevent2022/libevent/evdns.c cb(EVUTIL_EAI_FAIL, NULL, arg); cb 499 opal/mca/event/libevent2022/libevent/event.c event_deferred_cb_queue_init(struct deferred_cb_queue *cb) cb 501 opal/mca/event/libevent2022/libevent/event.c memset(cb, 0, sizeof(struct deferred_cb_queue)); cb 502 opal/mca/event/libevent2022/libevent/event.c TAILQ_INIT(&cb->deferred_cb_list); cb 507 opal/mca/event/libevent2022/libevent/event.c notify_base_cbq_callback(struct deferred_cb_queue *cb, void *baseptr) cb 1402 opal/mca/event/libevent2022/libevent/event.c struct deferred_cb *cb; cb 1405 opal/mca/event/libevent2022/libevent/event.c while ((cb = TAILQ_FIRST(&queue->deferred_cb_list))) { cb 1406 opal/mca/event/libevent2022/libevent/event.c cb->queued = 0; cb 1407 opal/mca/event/libevent2022/libevent/event.c TAILQ_REMOVE(&queue->deferred_cb_list, cb, cb_next); cb 1411 opal/mca/event/libevent2022/libevent/event.c cb->cb(cb, cb->arg); cb 1667 opal/mca/event/libevent2022/libevent/event.c void (*cb)(evutil_socket_t, short, void *); cb 1678 opal/mca/event/libevent2022/libevent/event.c (*eonce->cb)(fd, events, eonce->arg); cb 1710 opal/mca/event/libevent2022/libevent/event.c eonce->cb = callback; cb 1812 opal/mca/event/libevent2022/libevent/event.c event_new(struct event_base *base, evutil_socket_t fd, short events, void (*cb)(evutil_socket_t, short, void *), void *arg) cb 1818 opal/mca/event/libevent2022/libevent/event.c if (event_assign(ev, base, fd, events, cb, arg) < 0) { cb 2353 opal/mca/event/libevent2022/libevent/event.c event_deferred_cb_init(struct deferred_cb *cb, deferred_cb_fn fn, void *arg) cb 2355 opal/mca/event/libevent2022/libevent/event.c memset(cb, 0, sizeof(struct deferred_cb)); cb 2356 opal/mca/event/libevent2022/libevent/event.c cb->cb = fn; cb 2357 opal/mca/event/libevent2022/libevent/event.c cb->arg = arg; cb 2362 opal/mca/event/libevent2022/libevent/event.c struct deferred_cb *cb) cb 2372 opal/mca/event/libevent2022/libevent/event.c if (cb->queued) { cb 2373 opal/mca/event/libevent2022/libevent/event.c TAILQ_REMOVE(&queue->deferred_cb_list, cb, cb_next); cb 2375 opal/mca/event/libevent2022/libevent/event.c cb->queued = 0; cb 2382 opal/mca/event/libevent2022/libevent/event.c struct deferred_cb *cb) cb 2392 opal/mca/event/libevent2022/libevent/event.c if (!cb->queued) { cb 2393 opal/mca/event/libevent2022/libevent/event.c cb->queued = 1; cb 2394 opal/mca/event/libevent2022/libevent/event.c TAILQ_INSERT_TAIL(&queue->deferred_cb_list, cb, cb_next); cb 2774 opal/mca/event/libevent2022/libevent/event.c void (*cb)(evutil_socket_t, short, void *) = evthread_notify_drain_default; cb 2792 opal/mca/event/libevent2022/libevent/event.c cb = evthread_notify_drain_eventfd; cb 2841 opal/mca/event/libevent2022/libevent/event.c EV_READ|EV_PERSIST, cb, base); cb 48 opal/mca/event/libevent2022/libevent/event_iocp.c event_overlapped_init(struct event_overlapped *o, iocp_callback cb) cb 51 opal/mca/event/libevent2022/libevent/event_iocp.c o->cb = cb; cb 59 opal/mca/event/libevent2022/libevent/event_iocp.c eo->cb(eo, completion_key, nBytes, ok); cb 101 opal/mca/event/libevent2022/libevent/evrpc-internal.h void (*cb)(void *, enum EVRPC_HOOK_RESULT); cb 188 opal/mca/event/libevent2022/libevent/evrpc-internal.h void (*cb)(struct evrpc_status*, void *request, void *reply, void *arg); cb 121 opal/mca/event/libevent2022/libevent/evrpc.c int (*cb)(void *, struct evhttp_request *, struct evbuffer *, void *), cb 141 opal/mca/event/libevent2022/libevent/evrpc.c hook->process = cb; cb 228 opal/mca/event/libevent2022/libevent/evrpc.c void (*cb)(struct evrpc_req_generic *, void *), void *cb_arg) cb 233 opal/mca/event/libevent2022/libevent/evrpc.c rpc->cb = cb; cb 280 opal/mca/event/libevent2022/libevent/evrpc.c void (*cb)(void *, enum EVRPC_HOOK_RESULT)); cb 369 opal/mca/event/libevent2022/libevent/evrpc.c rpc->cb(rpc_state, rpc->cb_arg); cb 714 opal/mca/event/libevent2022/libevent/evrpc.c (*ctx->cb)(&status, ctx->request, ctx->reply, ctx->cb_arg); cb 759 opal/mca/event/libevent2022/libevent/evrpc.c (*ctx->cb)(&status, ctx->request, ctx->reply, ctx->cb_arg); cb 766 opal/mca/event/libevent2022/libevent/evrpc.c void (*cb)(void *, enum EVRPC_HOOK_RESULT)) cb 774 opal/mca/event/libevent2022/libevent/evrpc.c pause->cb = cb; cb 795 opal/mca/event/libevent2022/libevent/evrpc.c (*pause->cb)(pause->ctx, res); cb 831 opal/mca/event/libevent2022/libevent/evrpc.c void (*cb)(struct evrpc_status *, void *, void *, void *), cb 847 opal/mca/event/libevent2022/libevent/evrpc.c ctx->cb = cb; cb 943 opal/mca/event/libevent2022/libevent/evrpc.c (*ctx->cb)(&status, ctx->request, ctx->reply, ctx->cb_arg); cb 1084 opal/mca/event/libevent2022/libevent/evrpc.c void (*cb)(struct evrpc_status *, void *, void *, void *), cb 1094 opal/mca/event/libevent2022/libevent/evrpc.c rpcname, req_marshal, rpl_clear, rpl_unmarshal, cb, cb_arg); cb 1101 opal/mca/event/libevent2022/libevent/evrpc.c (*(cb))(&status, request, reply, cb_arg); cb 1169 opal/mca/event/libevent2022/libevent/evrpc.c void (*cb)(struct evrpc_status*, void *request, void *reply, void *arg), cb 1172 opal/mca/event/libevent2022/libevent/evrpc.c ctx->cb = cb; cb 1412 opal/mca/event/libevent2022/libevent/evutil.c void (*cb)(int, struct evutil_addrinfo *, void *), void *arg) cb 1416 opal/mca/event/libevent2022/libevent/evutil.c dns_base, nodename, servname, hints_in, cb, arg); cb 1421 opal/mca/event/libevent2022/libevent/evutil.c cb(err, ai, arg); cb 97 opal/mca/event/libevent2022/libevent/http-internal.h void (*cb)(struct evhttp_connection *, void *); cb 115 opal/mca/event/libevent2022/libevent/http-internal.h void (*cb)(struct evhttp_request *req, void *); cb 378 opal/mca/event/libevent2022/libevent/http.c void (*cb)(struct evhttp_connection *, void *), void *arg) cb 383 opal/mca/event/libevent2022/libevent/http.c evcon->cb = cb; cb 412 opal/mca/event/libevent2022/libevent/http.c evcon->cb = evhttp_send_continue_done; cb 687 opal/mca/event/libevent2022/libevent/http.c (*req->cb)(req, req->cb_arg); cb 702 opal/mca/event/libevent2022/libevent/http.c void (*cb)(struct evhttp_request *, void *); cb 725 opal/mca/event/libevent2022/libevent/http.c cb = req->cb; cb 728 opal/mca/event/libevent2022/libevent/http.c cb = NULL; cb 747 opal/mca/event/libevent2022/libevent/http.c if (cb != NULL) cb 748 opal/mca/event/libevent2022/libevent/http.c (*cb)(NULL, cb_arg); cb 759 opal/mca/event/libevent2022/libevent/http.c if (evcon->cb != NULL) cb 760 opal/mca/event/libevent2022/libevent/http.c (*evcon->cb)(evcon, evcon->cb_arg); cb 817 opal/mca/event/libevent2022/libevent/http.c (*req->cb)(req, req->cb_arg); cb 1099 opal/mca/event/libevent2022/libevent/http.c evhttp_deferred_read_cb(struct deferred_cb *cb, void *data) cb 1317 opal/mca/event/libevent2022/libevent/http.c request->cb(request, request->cb_arg); cb 2167 opal/mca/event/libevent2022/libevent/http.c void (*cb)(struct evhttp_connection *, void *), void *cbarg) cb 2169 opal/mca/event/libevent2022/libevent/http.c evcon->closecb = cb; cb 2514 opal/mca/event/libevent2022/libevent/http.c evcon->cb = evhttp_send_done; cb 2877 opal/mca/event/libevent2022/libevent/http.c struct evhttp_cb *cb; cb 2890 opal/mca/event/libevent2022/libevent/http.c TAILQ_FOREACH(cb, callbacks, next) { cb 2891 opal/mca/event/libevent2022/libevent/http.c if (!strcmp(cb->what, translated)) { cb 2893 opal/mca/event/libevent2022/libevent/http.c return (cb); cb 3008 opal/mca/event/libevent2022/libevent/http.c struct evhttp_cb *cb = NULL; cb 3032 opal/mca/event/libevent2022/libevent/http.c if ((cb = evhttp_dispatch_callback(&http->callbacks, req)) != NULL) { cb 3033 opal/mca/event/libevent2022/libevent/http.c (*cb->cb)(req, cb->cbarg); cb 3402 opal/mca/event/libevent2022/libevent/http.c void (*cb)(struct evhttp_request *, void *), void *cbarg) cb 3422 opal/mca/event/libevent2022/libevent/http.c http_cb->cb = cb; cb 3451 opal/mca/event/libevent2022/libevent/http.c void (*cb)(struct evhttp_request *, void *), void *cbarg) cb 3453 opal/mca/event/libevent2022/libevent/http.c http->gencb = cb; cb 3462 opal/mca/event/libevent2022/libevent/http.c evhttp_request_new(void (*cb)(struct evhttp_request *, void *), void *arg) cb 3500 opal/mca/event/libevent2022/libevent/http.c req->cb = cb; cb 3571 opal/mca/event/libevent2022/libevent/http.c void (*cb)(struct evhttp_request *, void *)) cb 3573 opal/mca/event/libevent2022/libevent/http.c req->chunk_cb = cb; cb 701 opal/mca/event/libevent2022/libevent/include/event2/buffer.h struct evbuffer_cb_entry *evbuffer_add_cb(struct evbuffer *buffer, evbuffer_cb_func cb, void *cbarg); cb 720 opal/mca/event/libevent2022/libevent/include/event2/buffer.h int evbuffer_remove_cb(struct evbuffer *buffer, evbuffer_cb_func cb, void *cbarg); cb 737 opal/mca/event/libevent2022/libevent/include/event2/buffer.h struct evbuffer_cb_entry *cb, ev_uint32_t flags); cb 747 opal/mca/event/libevent2022/libevent/include/event2/buffer.h struct evbuffer_cb_entry *cb, ev_uint32_t flags); cb 759 opal/mca/event/libevent2022/libevent/include/event2/buffer.h void evbuffer_cb_suspend(struct evbuffer *buffer, struct evbuffer_cb_entry *cb); cb 768 opal/mca/event/libevent2022/libevent/include/event2/buffer.h void evbuffer_cb_unsuspend(struct evbuffer *buffer, struct evbuffer_cb_entry *cb); cb 91 opal/mca/event/libevent2022/libevent/include/event2/buffer_compat.h void evbuffer_setcb(struct evbuffer *buffer, evbuffer_cb cb, void *cbarg); cb 632 opal/mca/event/libevent2022/libevent/include/event2/dns.h evdns_getaddrinfo_cb cb, void *arg); cb 603 opal/mca/event/libevent2022/libevent/include/event2/event.h void event_set_log_callback(event_log_cb cb); cb 624 opal/mca/event/libevent2022/libevent/include/event2/event.h void event_set_fatal_callback(event_fatal_cb cb); cb 762 opal/mca/event/libevent2022/libevent/include/event2/event.h #define evtimer_assign(ev, b, cb, arg) \ cb 763 opal/mca/event/libevent2022/libevent/include/event2/event.h event_assign((ev), (b), -1, 0, (cb), (arg)) cb 764 opal/mca/event/libevent2022/libevent/include/event2/event.h #define evtimer_new(b, cb, arg) event_new((b), -1, 0, (cb), (arg)) cb 778 opal/mca/event/libevent2022/libevent/include/event2/event.h #define evsignal_assign(ev, b, x, cb, arg) \ cb 779 opal/mca/event/libevent2022/libevent/include/event2/event.h event_assign((ev), (b), (x), EV_SIGNAL|EV_PERSIST, cb, (arg)) cb 780 opal/mca/event/libevent2022/libevent/include/event2/event.h #define evsignal_new(b, x, cb, arg) \ cb 781 opal/mca/event/libevent2022/libevent/include/event2/event.h event_new((b), (x), EV_SIGNAL|EV_PERSIST, (cb), (arg)) cb 176 opal/mca/event/libevent2022/libevent/include/event2/event_compat.h #define evtimer_set(ev, cb, arg) event_set((ev), -1, 0, (cb), (arg)) cb 177 opal/mca/event/libevent2022/libevent/include/event2/event_compat.h #define evsignal_set(ev, x, cb, arg) \ cb 178 opal/mca/event/libevent2022/libevent/include/event2/event_compat.h event_set((ev), (x), EV_SIGNAL|EV_PERSIST, (cb), (arg)) cb 189 opal/mca/event/libevent2022/libevent/include/event2/event_compat.h #define timeout_set(ev, cb, arg) event_set((ev), -1, 0, (cb), (arg)) cb 203 opal/mca/event/libevent2022/libevent/include/event2/event_compat.h #define signal_set(ev, x, cb, arg) \ cb 204 opal/mca/event/libevent2022/libevent/include/event2/event_compat.h event_set((ev), (x), EV_SIGNAL|EV_PERSIST, (cb), (arg)) cb 217 opal/mca/event/libevent2022/libevent/include/event2/http.h void (*cb)(struct evhttp_request *, void *), void *cb_arg); cb 234 opal/mca/event/libevent2022/libevent/include/event2/http.h void (*cb)(struct evhttp_request *, void *), void *arg); cb 398 opal/mca/event/libevent2022/libevent/include/event2/http.h void (*cb)(struct evhttp_request *, void *), void *arg); cb 408 opal/mca/event/libevent2022/libevent/include/event2/http.h void (*cb)(struct evhttp_request *, void *)); cb 114 opal/mca/event/libevent2022/libevent/include/event2/http_struct.h void (*cb)(struct evhttp_request *, void *); cb 91 opal/mca/event/libevent2022/libevent/include/event2/listener.h evconnlistener_cb cb, void *ptr, unsigned flags, int backlog, cb 109 opal/mca/event/libevent2022/libevent/include/event2/listener.h evconnlistener_cb cb, void *ptr, unsigned flags, int backlog, cb 133 opal/mca/event/libevent2022/libevent/include/event2/listener.h evconnlistener_cb cb, void *arg); cb 196 opal/mca/event/libevent2022/libevent/include/event2/rpc.h void (*cb)(struct evrpc_status *, void *, void *, void *), cb 214 opal/mca/event/libevent2022/libevent/include/event2/rpc.h pool, request, reply, cb, cbarg) \ cb 220 opal/mca/event/libevent2022/libevent/include/event2/rpc.h (void (*)(struct evrpc_status *, void *, void *, void *))cb, \ cb 236 opal/mca/event/libevent2022/libevent/include/event2/rpc.h void (*cb)(struct evrpc_status *, \ cb 240 opal/mca/event/libevent2022/libevent/include/event2/rpc.h (void (*)(struct evrpc_status *, void *, void *, void *))cb, \ cb 374 opal/mca/event/libevent2022/libevent/include/event2/rpc.h #define EVRPC_MAKE_REQUEST(name, pool, request, reply, cb, cbarg) \ cb 375 opal/mca/event/libevent2022/libevent/include/event2/rpc.h evrpc_send_request_##name((pool), (request), (reply), (cb), (cbarg)) cb 494 opal/mca/event/libevent2022/libevent/include/event2/rpc.h int (*cb)(void *, struct evhttp_request *, struct evbuffer *, void *), cb 561 opal/mca/event/libevent2022/libevent/include/event2/rpc.h void (*cb)(struct evrpc_status *, void *, void *, void *), cb 589 opal/mca/event/libevent2022/libevent/include/event2/rpc.h void (*cb)(struct evrpc_status*, void *request, void *reply, void *arg), cb 89 opal/mca/event/libevent2022/libevent/include/event2/rpc_struct.h void (*cb)(struct evrpc_req_generic *, void *); cb 53 opal/mca/event/libevent2022/libevent/iocp-internal.h iocp_callback cb; cb 99 opal/mca/event/libevent2022/libevent/iocp-internal.h iocp_callback cb; cb 109 opal/mca/event/libevent2022/libevent/iocp-internal.h void event_overlapped_init(struct event_overlapped *, iocp_callback cb); cb 77 opal/mca/event/libevent2022/libevent/listener.c evconnlistener_cb cb; cb 108 opal/mca/event/libevent2022/libevent/listener.c evconnlistener_cb cb, void *ptr, unsigned flags, int backlog, cb 155 opal/mca/event/libevent2022/libevent/listener.c evconnlistener_cb cb, void *ptr, unsigned flags, int backlog, cb 165 opal/mca/event/libevent2022/libevent/listener.c return evconnlistener_new_async(base, cb, ptr, flags, cb 183 opal/mca/event/libevent2022/libevent/listener.c lev->base.cb = cb; cb 201 opal/mca/event/libevent2022/libevent/listener.c evconnlistener_new_bind(struct event_base *base, evconnlistener_cb cb, cb 247 opal/mca/event/libevent2022/libevent/listener.c listener = evconnlistener_new(base, cb, ptr, flags, backlog, fd); cb 260 opal/mca/event/libevent2022/libevent/listener.c lev->cb = NULL; cb 285 opal/mca/event/libevent2022/libevent/listener.c if (lev->cb) cb 358 opal/mca/event/libevent2022/libevent/listener.c evconnlistener_cb cb, void *arg) cb 362 opal/mca/event/libevent2022/libevent/listener.c if (lev->enabled && !lev->cb) cb 364 opal/mca/event/libevent2022/libevent/listener.c lev->cb = cb; cb 385 opal/mca/event/libevent2022/libevent/listener.c evconnlistener_cb cb; cb 409 opal/mca/event/libevent2022/libevent/listener.c if (lev->cb == NULL) { cb 415 opal/mca/event/libevent2022/libevent/listener.c cb = lev->cb; cb 418 opal/mca/event/libevent2022/libevent/listener.c cb(lev, new_fd, (struct sockaddr*)&ss, (int)socklen, cb 462 opal/mca/event/libevent2022/libevent/listener.c static void accepted_socket_invoke_user_cb(struct deferred_cb *cb, void *arg); cb 603 opal/mca/event/libevent2022/libevent/listener.c evconnlistener_cb cb=NULL; cb 629 opal/mca/event/libevent2022/libevent/listener.c cb = lev->cb; cb 646 opal/mca/event/libevent2022/libevent/listener.c } else if (cb) { cb 647 opal/mca/event/libevent2022/libevent/listener.c cb(lev, sock, sa_remote, socklen_remote, data); cb 801 opal/mca/event/libevent2022/libevent/listener.c evconnlistener_cb cb, void *ptr, unsigned flags, int backlog, cb 832 opal/mca/event/libevent2022/libevent/listener.c lev->base.cb = cb; cb 861 opal/mca/event/libevent2022/libevent/listener.c if (cb && start_accepting(lev->accepting[i]) < 0) { cb 71 opal/mca/event/libevent2022/libevent/log.c event_set_fatal_callback(event_fatal_cb cb) cb 73 opal/mca/event/libevent2022/libevent/log.c fatal_fn = cb; cb 197 opal/mca/event/libevent2022/libevent/log.c event_set_log_callback(event_log_cb cb) cb 199 opal/mca/event/libevent2022/libevent/log.c log_fn = cb; cb 97 opal/mca/event/libevent2022/libevent/test/regress_testutils.c evdns_request_callback_fn_type cb, cb 119 opal/mca/event/libevent2022/libevent/test/regress_testutils.c port = evdns_add_server_port_with_base(base, sock, 0, cb, arg); cb 43 opal/mca/event/libevent2022/libevent/test/regress_testutils.h evdns_request_callback_fn_type cb, cb 424 opal/mca/event/libevent2022/libevent/test/regress_thread.c deferred_callback(struct deferred_cb *cb, void *arg) cb 144 opal/mca/event/libevent2022/libevent/test/tinytest.c si.cb = sizeof(si); cb 256 opal/mca/event/libevent2022/libevent/util-internal.h void (*cb)(int, struct evutil_addrinfo *, void *), void *arg); cb 111 opal/mca/event/libevent2022/libevent2022.h #define opal_event_set(b, x, fd, fg, cb, arg) event_assign((x), (b), (fd), (fg), (event_callback_fn) (cb), (arg)) cb 113 opal/mca/event/libevent2022/libevent2022.h #define opal_event_assign(x, b, fd, fg, cb, arg) event_assign((x), (b), (fd), (fg), (event_callback_fn) (cb), (arg)) cb 121 opal/mca/event/libevent2022/libevent2022.h #define opal_event_new(b, fd, fg, cb, arg) event_new((b), (fd), (fg), (event_callback_fn) (cb), (arg)) cb 128 opal/mca/event/libevent2022/libevent2022.h #define opal_event_evtimer_new(b, cb, arg) opal_event_new((b), -1, 0, (cb), (arg)) cb 132 opal/mca/event/libevent2022/libevent2022.h #define opal_event_evtimer_set(b, x, cb, arg) event_assign((x), (b), -1, 0, (event_callback_fn) (cb), (arg)) cb 143 opal/mca/event/libevent2022/libevent2022.h #define opal_event_signal_set(b, x, fd, cb, arg) event_assign((x), (b), (fd), EV_SIGNAL|EV_PERSIST, (event_callback_fn) (cb), (arg)) cb 200 opal/mca/hwloc/hwloc201/hwloc/hwloc/pci-common.c void (*cb)(void * cbdata, struct hwloc_obj *)) cb 203 opal/mca/hwloc/hwloc201/hwloc/hwloc/pci-common.c cb(cbdata, tree); cb 206 opal/mca/hwloc/hwloc201/hwloc/hwloc/pci-common.c hwloc_pci_traverse(cbdata, child, cb); cb 1025 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-linux.c pid_t pid, hwloc_linux_foreach_proc_tid_cb_t cb, cb 1057 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-linux.c err = cb(topology, tids[i], data, i); cb 2605 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-linux.c ssize_t cb = read(file, ret, fs.st_size); cb 2606 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-linux.c if (cb == -1) { cb 2611 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-linux.c *bytes_read = cb; cb 2626 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-linux.c size_t cb = 0; cb 2627 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-linux.c char *ret = hwloc_read_raw(p, p1, &cb, root_fd); cb 2628 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-linux.c if ((NULL != ret) && (0 < cb) && (0 != ret[cb-1])) { cb 2629 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-linux.c char *tmp = realloc(ret, cb + 1); cb 2635 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-linux.c ret[cb] = 0; cb 2644 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-linux.c size_t cb = 0; cb 2645 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-linux.c uint32_t *tmp = hwloc_read_raw(p, p1, &cb, root_fd); cb 2646 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-linux.c if (sizeof(*buf) != cb) { cb 2853 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-linux.c size_t cb = 0; cb 2854 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-linux.c uint32_t *threads = hwloc_read_raw(cpu, "ibm,ppc-interrupt-server#s", &cb, root_fd); cb 2855 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-linux.c uint32_t nthreads = cb / sizeof(threads[0]); cb 228 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-windows.c typedef BOOL (WINAPI *PFN_QUERYWORKINGSETEX)(HANDLE hProcess, PVOID pv, DWORD cb); cb 168 opal/mca/pmix/ext2x/ext2x.h #define OPAL_PMIX_OP_THREADSHIFT(e, fn, cb, cd) \ cb 173 opal/mca/pmix/ext2x/ext2x.h _cd->opcbfunc = (cb); \ cb 181 opal/mca/pmix/ext2x/ext2x.h #define OPAL_PMIX_THREADSHIFT(e, i, eh, fn, cb, cd) \ cb 188 opal/mca/pmix/ext2x/ext2x.h _cd->cbfunc = (cb); \ cb 196 opal/mca/pmix/ext2x/ext2x.h #define OPAL_PMIX_NOTIFY_THREADSHIFT(s, sr, r, i, fn, cb, cd) \ cb 204 opal/mca/pmix/ext2x/ext2x.h _cd->opcbfunc = (cb); \ cb 212 opal/mca/pmix/ext2x/ext2x.h #define OPAL_PMIX2X_THREADSHIFT(p, cb) \ cb 215 opal/mca/pmix/ext2x/ext2x.h -1, EV_WRITE, (cb), (p)); \ cb 163 opal/mca/pmix/ext3x/ext3x.h #define OPAL_PMIX_OP_THREADSHIFT(e, fn, cb, cd) \ cb 168 opal/mca/pmix/ext3x/ext3x.h _cd->opcbfunc = (cb); \ cb 176 opal/mca/pmix/ext3x/ext3x.h #define OPAL_PMIX_THREADSHIFT(e, i, eh, fn, cb, cd) \ cb 183 opal/mca/pmix/ext3x/ext3x.h _cd->cbfunc = (cb); \ cb 191 opal/mca/pmix/ext3x/ext3x.h #define OPAL_PMIX_NOTIFY_THREADSHIFT(s, sr, r, i, fn, cb, cd) \ cb 199 opal/mca/pmix/ext3x/ext3x.h _cd->opcbfunc = (cb); \ cb 207 opal/mca/pmix/ext3x/ext3x.h #define OPAL_PMIX2X_THREADSHIFT(p, cb) \ cb 210 opal/mca/pmix/ext3x/ext3x.h -1, EV_WRITE, (cb), (p)); \ cb 218 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c pmix_cb_t *cb = (pmix_cb_t*)cbdata; cb 225 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c cb->status = PMIX_ERROR; cb 226 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_POST_OBJECT(cb); cb 227 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_WAKEUP_THREAD(&cb->lock); cb 232 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_GDS_STORE_JOB_INFO(cb->status, cb 236 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c cb->status = PMIX_SUCCESS; cb 237 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_POST_OBJECT(cb); cb 238 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_WAKEUP_THREAD(&cb->lock); cb 424 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c pmix_cb_t cb; cb 643 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_CONSTRUCT(&cb, pmix_cb_t); cb 645 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c req, job_data, (void*)&cb); cb 652 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_WAIT_THREAD(&cb.lock); cb 653 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c rc = cb.status; cb 654 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_DESTRUCT(&cb); cb 962 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c pmix_cb_t *cb = (pmix_cb_t*)cbdata; cb 969 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_ACQUIRE_OBJECT(cb); cb 973 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c if (0 == strncmp(cb->key, "pmix", 4)) { cb 980 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c kv->key = strdup(cb->key); // need to copy as the input belongs to the user cb 982 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c if (PMIX_STRING_SIZE_CHECK(cb->value)) { cb 984 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c if (pmix_compress.compress_string(cb->value->data.string, &tmp, &len)) { cb 997 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c kv->value, cb->value); cb 1001 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c kv->value, cb->value); cb 1011 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c cb->scope, kv); cb 1024 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c cb->pstatus = rc; cb 1026 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_POST_OBJECT(cb); cb 1027 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_WAKEUP_THREAD(&cb->lock); cb 1034 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c pmix_cb_t *cb; cb 1049 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c cb = PMIX_NEW(pmix_cb_t); cb 1050 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c cb->scope = scope; cb 1051 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c cb->key = (char*)key; cb 1052 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c cb->value = val; cb 1055 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_THREADSHIFT(cb, _putfn); cb 1058 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_WAIT_THREAD(&cb->lock); cb 1059 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c rc = cb->pstatus; cb 1060 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_RELEASE(cb); cb 1067 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c pmix_cb_t *cb = (pmix_cb_t*)cbdata; cb 1075 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_ACQUIRE_OBJECT(cb); cb 1094 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c cb->proc = &pmix_globals.myid; cb 1095 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c cb->scope = scope; cb 1096 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c cb->copy = false; cb 1097 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_GDS_FETCH_KV(rc, pmix_globals.mypeer, cb); cb 1107 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_LIST_FOREACH_SAFE(kv, kvn, &cb->kvs, pmix_kval_t) { cb 1116 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c pmix_list_remove_item(&cb->kvs, &kv->super); cb 1135 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c cb->proc = &pmix_globals.myid; cb 1136 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c cb->scope = scope; cb 1137 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c cb->copy = true; cb 1138 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_GDS_FETCH_KV(rc, pmix_globals.mypeer, cb); cb 1148 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_LIST_FOREACH_SAFE(kv, kvn, &cb->kvs, pmix_kval_t) { cb 1157 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c pmix_list_remove_item(&cb->kvs, &kv->super); cb 1178 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c wait_cbfunc, (void*)&cb->lock); cb 1182 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c cb->pstatus = PMIX_SUCCESS; cb 1187 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c cb->pstatus = rc; cb 1189 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_POST_OBJECT(cb); cb 1190 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_WAKEUP_THREAD(&cb->lock); cb 1195 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c pmix_cb_t *cb; cb 1216 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c cb = PMIX_NEW(pmix_cb_t); cb 1218 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_THREADSHIFT(cb, _commitfn); cb 1221 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_WAIT_THREAD(&cb->lock); cb 1222 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c rc = cb->pstatus; cb 1223 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_RELEASE(cb); cb 1230 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c pmix_cb_t *cb = (pmix_cb_t*)cbdata; cb 1232 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c cb->status = pmix_preg.resolve_peers(cb->key, cb->pname.nspace, cb 1233 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c &cb->procs, &cb->nprocs); cb 1235 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_POST_OBJECT(cb); cb 1236 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_WAKEUP_THREAD(&cb->lock); cb 1244 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c pmix_cb_t *cb; cb 1256 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c cb = PMIX_NEW(pmix_cb_t); cb 1257 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c cb->key = (char*)nodename; cb 1258 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c cb->pname.nspace = strdup(nspace); cb 1260 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_THREADSHIFT(cb, _resolve_peers); cb 1263 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_WAIT_THREAD(&cb->lock); cb 1267 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c if (PMIX_ERR_INVALID_NAMESPACE == cb->status) { cb 1274 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_RELEASE(cb); cb 1278 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c cb->lock.active = true; cb 1279 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_THREADSHIFT(cb, _resolve_peers); cb 1280 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_WAIT_THREAD(&cb->lock); cb 1282 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c *procs = cb->procs; cb 1283 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c *nprocs = cb->nprocs; cb 1285 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c rc = cb->status; cb 1286 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_RELEASE(cb); cb 1292 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c pmix_cb_t *cb = (pmix_cb_t*)cbdata; cb 1296 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c cb->status = pmix_preg.resolve_nodes(cb->pname.nspace, ®ex); cb 1297 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c if (PMIX_SUCCESS == cb->status) { cb 1299 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c cb->status = pmix_preg.parse_nodes(regex, &names); cb 1300 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c if (PMIX_SUCCESS == cb->status) { cb 1302 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c cb->key = pmix_argv_join(names, ','); cb 1309 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_POST_OBJECT(cb); cb 1310 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_WAKEUP_THREAD(&cb->lock); cb 1316 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c pmix_cb_t *cb; cb 1327 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c cb = PMIX_NEW(pmix_cb_t); cb 1328 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c cb->pname.nspace = strdup(nspace); cb 1330 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_THREADSHIFT(cb, _resolve_nodes); cb 1333 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_WAIT_THREAD(&cb->lock); cb 1337 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c if (PMIX_ERR_INVALID_NAMESPACE == cb->status) { cb 1344 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_RELEASE(cb); cb 1348 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c cb->lock.active = true; cb 1349 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_THREADSHIFT(cb, _resolve_nodes); cb 1350 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_WAIT_THREAD(&cb->lock); cb 1353 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c *nodelist = cb->key; cb 1355 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c rc = cb->status; cb 1356 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c PMIX_RELEASE(cb); cb 70 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c pmix_cb_t *cb; cb 92 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c cb = PMIX_NEW(pmix_cb_t); cb 95 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c if (PMIX_SUCCESS != (rc = PMIx_Connect_nb(procs, nprocs, info, ninfo, op_cbfunc, cb))) { cb 96 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c PMIX_RELEASE(cb); cb 101 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c PMIX_WAIT_THREAD(&cb->lock); cb 102 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c rc = cb->status; cb 103 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c PMIX_RELEASE(cb); cb 118 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c pmix_cb_t *cb; cb 186 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c cb = PMIX_NEW(pmix_cb_t); cb 187 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c cb->cbfunc.opfn = cbfunc; cb 188 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c cb->cbdata = cbdata; cb 192 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c msg, wait_cbfunc, (void*)cb); cb 195 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c PMIX_RELEASE(cb); cb 205 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c pmix_cb_t *cb; cb 223 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c cb = PMIX_NEW(pmix_cb_t); cb 225 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c if (PMIX_SUCCESS != (rc = PMIx_Disconnect_nb(procs, nprocs, info, ninfo, op_cbfunc, cb))) { cb 226 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c PMIX_RELEASE(cb); cb 231 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c PMIX_WAIT_THREAD(&cb->lock); cb 232 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c rc = cb->status; cb 233 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c PMIX_RELEASE(cb); cb 248 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c pmix_cb_t *cb; cb 323 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c cb = PMIX_NEW(pmix_cb_t); cb 324 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c cb->cbfunc.opfn = cbfunc; cb 325 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c cb->cbdata = cbdata; cb 329 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c msg, wait_cbfunc, (void*)cb); cb 332 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c PMIX_RELEASE(cb); cb 345 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c pmix_cb_t *cb = (pmix_cb_t*)cbdata; cb 414 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c if (NULL != cb->cbfunc.opfn) { cb 415 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c cb->cbfunc.opfn(ret, cb->cbdata); cb 417 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c PMIX_RELEASE(cb); cb 422 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c pmix_cb_t *cb = (pmix_cb_t*)cbdata; cb 424 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c cb->status = status; cb 425 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c PMIX_POST_OBJECT(cb); cb 426 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c PMIX_WAKEUP_THREAD(&cb->lock); cb 70 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_fence.c pmix_cb_t *cb; cb 93 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_fence.c cb = PMIX_NEW(pmix_cb_t); cb 97 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_fence.c op_cbfunc, cb))) { cb 99 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_fence.c PMIX_RELEASE(cb); cb 104 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_fence.c PMIX_WAIT_THREAD(&cb->lock); cb 105 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_fence.c rc = cb->status; cb 106 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_fence.c PMIX_RELEASE(cb); cb 121 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_fence.c pmix_cb_t *cb; cb 167 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_fence.c cb = PMIX_NEW(pmix_cb_t); cb 168 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_fence.c cb->cbfunc.opfn = cbfunc; cb 169 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_fence.c cb->cbdata = cbdata; cb 173 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_fence.c msg, wait_cbfunc, (void*)cb); cb 176 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_fence.c PMIX_RELEASE(cb); cb 254 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_fence.c pmix_cb_t *cb = (pmix_cb_t*)cbdata; cb 260 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_fence.c if (NULL == cb) { cb 273 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_fence.c if (NULL != cb->cbfunc.opfn) { cb 274 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_fence.c cb->cbfunc.opfn(rc, cb->cbdata); cb 276 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_fence.c PMIX_RELEASE(cb); cb 281 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_fence.c pmix_cb_t *cb = (pmix_cb_t*)cbdata; cb 283 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_fence.c cb->status = status; cb 284 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_fence.c PMIX_WAKEUP_THREAD(&cb->lock); cb 78 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c static pmix_status_t process_values(pmix_value_t **v, pmix_cb_t *cb); cb 86 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c pmix_cb_t *cb; cb 111 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c cb = PMIX_NEW(pmix_cb_t); cb 112 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c if (PMIX_SUCCESS != (rc = PMIx_Get_nb(proc, key, info, ninfo, _value_cbfunc, cb))) { cb 113 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c PMIX_RELEASE(cb); cb 118 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c PMIX_WAIT_THREAD(&cb->lock); cb 119 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c rc = cb->status; cb 121 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c *val = cb->value; cb 122 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c cb->value = NULL; cb 124 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c PMIX_RELEASE(cb); cb 137 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c pmix_cb_t *cb; cb 196 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c cb = PMIX_NEW(pmix_cb_t); cb 197 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c cb->pname.nspace = strdup(nm); cb 198 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c cb->pname.rank = rank; cb 199 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c cb->key = (char*)key; cb 200 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c cb->info = (pmix_info_t*)info; cb 201 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c cb->ninfo = ninfo; cb 202 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c cb->cbfunc.valuefn = cbfunc; cb 203 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c cb->cbdata = cbdata; cb 204 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c PMIX_THREADSHIFT(cb, _getnbfn); cb 211 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c pmix_cb_t *cb = (pmix_cb_t*)cbdata; cb 214 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c PMIX_ACQUIRE_OBJECT(cb); cb 215 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c cb->status = status; cb 218 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c (void**)&cb->value, kv, PMIX_VALUE); cb 223 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c PMIX_POST_OBJECT(cb); cb 224 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c PMIX_WAKEUP_THREAD(&cb->lock); cb 288 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c pmix_cb_t *cb = (pmix_cb_t*)cbdata; cb 299 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c if (NULL == cb) { cb 306 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c pmix_strncpy(proc.nspace, cb->pname.nspace, PMIX_MAX_NSLEN); cb 307 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c proc.rank = cb->pname.rank; cb 322 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c pmix_list_remove_item(&pmix_client_globals.pending_requests, &cb->super); cb 323 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c PMIX_RELEASE(cb); cb 340 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c PMIX_LIST_FOREACH_SAFE(cb, cb2, &pmix_client_globals.pending_requests, pmix_cb_t) { cb 341 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c if (0 == strncmp(proc.nspace, cb->pname.nspace, PMIX_MAX_NSLEN) && cb 342 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c cb->pname.rank == proc.rank) { cb 344 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c cb->proc = &proc; cb 345 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c cb->scope = PMIX_SCOPE_UNDEF; cb 348 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c cb->copy = true; cb 349 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c PMIX_GDS_FETCH_KV(rc, pmix_client_globals.myserver, cb); cb 351 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c if (1 != pmix_list_get_size(&cb->kvs)) { cb 355 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c kv = (pmix_kval_t*)pmix_list_remove_first(&cb->kvs); cb 361 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c cb->cbfunc.valuefn(rc, val, cb->cbdata); cb 362 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c pmix_list_remove_item(&pmix_client_globals.pending_requests, &cb->super); cb 363 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c PMIX_RELEASE(cb); cb 370 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c pmix_cb_t *cb = (pmix_cb_t*)cbdata; cb 373 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c cb->cbfunc.valuefn(PMIX_ERR_TIMEOUT, NULL, cb->cbdata); cb 374 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c cb->timer_running = false; cb 377 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c pmix_list_remove_item(&pmix_client_globals.pending_requests, &cb->super); cb 378 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c PMIX_RELEASE(cb); cb 381 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c static pmix_status_t process_values(pmix_value_t **v, pmix_cb_t *cb) cb 383 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c pmix_list_t *kvs = &cb->kvs; cb 389 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c if (NULL != cb->key && 1 == pmix_list_get_size(kvs)) { cb 490 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c pmix_cb_t *cb = PMIX_NEW(pmix_cb_t); cb 498 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c cb->scope = info[n].value.data.scope; cb 503 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c cb->proc = (pmix_proc_t*)proc; cb 504 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c cb->copy = true; cb 505 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c cb->key = (char*)key; cb 506 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c cb->info = (pmix_info_t*)info; cb 507 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c cb->ninfo = ninfo; cb 511 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c PMIX_GDS_FETCH_KV(rc, pmix_globals.mypeer, cb); cb 518 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c PMIX_GDS_FETCH_KV(rc, pmix_client_globals.myserver, cb); cb 523 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c PMIX_RELEASE(cb); cb 527 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c rc = process_values(val, cb); cb 531 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c PMIX_RELEASE(cb); cb 537 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c pmix_cb_t *cb = (pmix_cb_t*)cbdata; cb 550 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c PMIX_ACQUIRE_OBJECT(cb); cb 554 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c cb->pname.nspace, cb->pname.rank, cb 555 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c (NULL == cb->key) ? "NULL" : cb->key); cb 558 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c pmix_strncpy(proc.nspace, cb->pname.nspace, PMIX_MAX_NSLEN); cb 559 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c proc.rank = cb->pname.rank; cb 562 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c if (NULL != cb->info) { cb 563 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c for (n=0; n < cb->ninfo; n++) { cb 564 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c if (0 == strncmp(cb->info[n].key, PMIX_OPTIONAL, PMIX_MAX_KEYLEN)) { cb 565 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c optional = PMIX_INFO_TRUE(&cb->info[n]); cb 566 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c } else if (0 == strncmp(cb->info[n].key, PMIX_IMMEDIATE, PMIX_MAX_KEYLEN)) { cb 567 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c immediate = PMIX_INFO_TRUE(&cb->info[n]); cb 568 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c } else if (0 == strncmp(cb->info[n].key, PMIX_TIMEOUT, PMIX_MAX_KEYLEN)) { cb 571 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c if (0 < cb->info[n].value.data.integer) { cb 572 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c tv.tv_sec = cb->info[n].value.data.integer; cb 574 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c pmix_event_evtimer_set(pmix_globals.evbase, &cb->ev, cb 575 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c timeout, cb); cb 576 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c pmix_event_evtimer_add(&cb->ev, &tv); cb 577 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c cb->timer_running = true; cb 579 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c } else if (0 == strncmp(cb->info[n].key, PMIX_DATA_SCOPE, PMIX_MAX_KEYLEN)) { cb 580 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c cb->scope = cb->info[n].value.data.scope; cb 586 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c cb->proc = &proc; cb 587 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c cb->copy = true; cb 588 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c PMIX_GDS_FETCH_KV(rc, pmix_globals.mypeer, cb); cb 592 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c rc = process_values(&val, cb); cb 600 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c if (NULL == cb->key || 0 == strncmp(cb->key, "pmix", 4)) { cb 601 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c cb->proc = &proc; cb 604 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c cb->copy = true; cb 605 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c PMIX_GDS_FETCH_KV(rc, pmix_client_globals.myserver, cb); cb 609 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c if (0 != strncmp(cb->pname.nspace, pmix_globals.myid.nspace, PMIX_MAX_NSLEN)) { cb 615 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c } else if (NULL != cb->key) { cb 628 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c cd->cbdata = cb->cbdata; cb 629 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c cd->valcbfunc = cb->cbfunc.valuefn; cb 632 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c pmix_argv_append_nosize(&cd->queries[0].keys, cb->key); cb 637 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c PMIX_RELEASE(cb); cb 652 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c rc = process_values(&val, cb); cb 655 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c cb->proc = &proc; cb 656 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c cb->copy = true; cb 657 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c PMIX_GDS_FETCH_KV(rc, pmix_client_globals.myserver, cb); cb 663 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c rc = process_values(&val, cb); cb 668 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c if (NULL != cb->cbfunc.valuefn) { cb 672 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c cb->cbfunc.valuefn(rc, val, cb->cbdata); cb 677 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c PMIX_RELEASE(cb); cb 696 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c cb->key, cb->pname.rank, cb->pname.nspace); cb 705 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c if (0 == strncmp(cbret->pname.nspace, cb->pname.nspace, PMIX_MAX_NSLEN) && cb 706 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c cbret->pname.rank == cb->pname.rank) { cb 709 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c pmix_list_append(&pmix_client_globals.pending_requests, &cb->super); cb 716 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c msg = _pack_get(cb->pname.nspace, cb->pname.rank, cb->info, cb->ninfo, PMIX_GETNB_CMD); cb 725 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c cb->pname.nspace, cb->pname.rank, cb->key); cb 728 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c pmix_list_append(&pmix_client_globals.pending_requests, &cb->super); cb 730 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c PMIX_PTL_SEND_RECV(rc, pmix_client_globals.myserver, msg, _getnb_cbfunc, (void*)cb); cb 732 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c pmix_list_remove_item(&pmix_client_globals.pending_requests, &cb->super); cb 738 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c PMIX_POST_OBJECT(cb); cb 127 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c pmix_group_tracker_t *cb; cb 149 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c cb = PMIX_NEW(pmix_group_tracker_t); cb 152 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c if (PMIX_SUCCESS != (rc = PMIx_Group_construct_nb(grp, procs, nprocs, info, ninfo, info_cbfunc, cb))) { cb 153 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_RELEASE(cb); cb 158 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_WAIT_THREAD(&cb->lock); cb 159 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c rc = cb->status; cb 161 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c *results = cb->results; cb 162 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c *nresults = cb->nresults; cb 163 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_RELEASE(cb); cb 179 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c pmix_group_tracker_t *cb = NULL; cb 279 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c cb = PMIX_NEW(pmix_group_tracker_t); cb 280 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c cb->cbfunc = cbfunc; cb 281 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c cb->cbdata = cbdata; cb 285 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c msg, grp_cbfunc, (void*)cb); cb 287 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_RELEASE(cb); cb 304 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c pmix_group_tracker_t cb; cb 326 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_CONSTRUCT(&cb, pmix_group_tracker_t); cb 329 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c if (PMIX_SUCCESS != (rc = PMIx_Group_destruct_nb(grp, info, ninfo, op_cbfunc, (void*)&cb))) { cb 331 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_DESTRUCT(&cb); cb 336 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_WAIT_THREAD(&cb.lock); cb 337 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c rc = cb.status; cb 338 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_DESTRUCT(&cb); cb 353 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c pmix_group_tracker_t *cb = NULL; cb 439 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c cb = PMIX_NEW(pmix_group_tracker_t); cb 440 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c cb->opcbfunc = cbfunc; cb 441 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c cb->cbdata = cbdata; cb 445 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c msg, grp_cbfunc, (void*)cb); cb 447 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_RELEASE(cb); cb 462 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c pmix_group_tracker_t *cb = (pmix_group_tracker_t*)cbdata; cb 464 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c if (NULL != cb) { cb 465 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_RELEASE(cb); cb 471 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c pmix_group_tracker_t *cb = (pmix_group_tracker_t*)cbdata; cb 473 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_RELEASE(cb); cb 484 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c pmix_group_tracker_t *cb = NULL; cb 496 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c cb = (pmix_group_tracker_t*)info[n].value.data.ptr; cb 506 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c if (NULL == cb) { cb 516 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c cb->accepted++; cb 525 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c cb->ninfo = 2; cb 526 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_INFO_CREATE(cb->info, cb->ninfo); cb 527 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_INFO_LOAD(&cb->info[0], PMIX_EVENT_AFFECTED_PROC, affected, PMIX_PROC); cb 528 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_INFO_LOAD(&cb->info[1], PMIX_GROUP_CONTEXT_ID, &contextid, PMIX_SIZE); cb 532 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c cb->info, cb->ninfo, cb 533 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c chaincbfunc, (void*)cb); cb 538 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_INFO_FREE(cb->info, cb->ninfo); cb 549 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c if (cb->accepted == cb->nmembers) { cb 551 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c if (NULL != cb->cbfunc) { cb 552 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c cb->cbfunc(PMIX_SUCCESS, NULL, 0, cb->cbdata, relcbfunc, cb); cb 558 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c cbfunc(rc, cb->results, cb->nresults, chaincbfunc, cb, cbdata); cb 566 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c pmix_cb_t *cb = (pmix_cb_t*)cbdata; cb 568 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c cb->status = status; cb 569 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c cb->errhandler_ref = refid; cb 570 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_WAKEUP_THREAD(&cb->lock); cb 578 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c pmix_group_tracker_t cb; cb 600 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_CONSTRUCT(&cb, pmix_group_tracker_t); cb 602 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c rc = PMIx_Group_invite_nb(grp, procs, nprocs, info, ninfo, info_cbfunc, (void*)&cb); cb 604 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_DESTRUCT(&cb); cb 609 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_WAIT_THREAD(&cb.lock); cb 610 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c rc = cb.status; cb 611 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c *results = cb.results; cb 612 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c *nresults = cb.nresults; cb 613 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_DESTRUCT(&cb); cb 618 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_CONSTRUCT(&cb, pmix_group_tracker_t); cb 619 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_INFO_CREATE(cb.info, 3); cb 620 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c if (NULL == cb.info) { cb 621 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_DESTRUCT(&cb); cb 624 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c cb.ninfo = 3; cb 626 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c (void)strncpy(cb.info[n].key, PMIX_EVENT_CUSTOM_RANGE, PMIX_MAX_KEYLEN); cb 627 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c cb.info[n].value.type = PMIX_DATA_ARRAY; cb 628 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_DATA_ARRAY_CREATE(cb.info[n].value.data.darray, nprocs, PMIX_PROC); cb 629 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c if (NULL == cb.info[n].value.data.darray || cb 630 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c NULL == cb.info[n].value.data.darray->array) { cb 631 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_DESTRUCT(&cb); cb 634 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c memcpy(cb.info[n].value.data.darray->array, procs, nprocs * sizeof(pmix_proc_t)); cb 637 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_INFO_LOAD(&cb.info[n], PMIX_EVENT_NON_DEFAULT, NULL, PMIX_BOOL); cb 640 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_INFO_LOAD(&cb.info[n], PMIX_GROUP_ID, grp, PMIX_STRING); cb 646 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c cb.info, cb.ninfo, cb 647 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c op_cbfunc, (void*)&cb); cb 649 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_DESTRUCT(&cb); cb 654 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_WAIT_THREAD(&cb.lock); cb 655 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c rc = cb.status; cb 656 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_DESTRUCT(&cb); cb 665 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c pmix_group_tracker_t *cb; cb 694 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c cb = PMIX_NEW(pmix_group_tracker_t); cb 695 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c if (NULL == cb) { cb 698 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c cb->cbfunc = cbfunc; cb 699 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c cb->cbdata = cbdata; cb 700 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c cb->accepted = 1; // obviously, we accept cb 707 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c cb->nmembers++; cb 713 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_INFO_LOAD(&myinfo[0], PMIX_EVENT_RETURN_OBJECT, cb, PMIX_POINTER); cb 721 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c cb->ref = lock.errhandler_ref; cb 726 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_RELEASE(cb); cb 741 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_INFO_CREATE(cb->info, 3); cb 742 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c if (NULL == cb->info) { cb 744 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIx_Deregister_event_handler(cb->ref, cb 748 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_RELEASE(cb); cb 751 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c cb->ninfo = 3; cb 753 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c (void)strncpy(cb->info[n].key, PMIX_EVENT_CUSTOM_RANGE, PMIX_MAX_KEYLEN); cb 754 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c cb->info[n].value.type = PMIX_DATA_ARRAY; cb 755 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_DATA_ARRAY_CREATE(cb->info[n].value.data.darray, nprocs, PMIX_PROC); cb 756 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c if (NULL == cb->info[n].value.data.darray || cb 757 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c NULL == cb->info[n].value.data.darray->array) { cb 759 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIx_Deregister_event_handler(cb->ref, cb 763 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_RELEASE(cb); cb 766 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c memcpy(cb->info[n].value.data.darray->array, procs, nprocs * sizeof(pmix_proc_t)); cb 769 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_INFO_LOAD(&cb->info[n], PMIX_EVENT_NON_DEFAULT, NULL, PMIX_BOOL); cb 772 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_INFO_LOAD(&cb->info[n], PMIX_GROUP_ID, grp, PMIX_STRING); cb 779 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c cb->info, cb->ninfo, cb 786 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIx_Deregister_event_handler(cb->ref, cb 790 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_RELEASE(cb); cb 803 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c pmix_group_tracker_t *cb; cb 821 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c cb = PMIX_NEW(pmix_group_tracker_t); cb 823 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c if (PMIX_SUCCESS != (rc = PMIx_Group_join_nb(grp, leader, opt, info, ninfo, info_cbfunc, cb))) { cb 824 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_RELEASE(cb); cb 829 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_WAIT_THREAD(&cb->lock); cb 830 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c rc = cb->status; cb 831 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_RELEASE(cb); cb 846 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c pmix_group_tracker_t *cb; cb 872 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c cb = PMIX_NEW(pmix_group_tracker_t); cb 873 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c cb->cbdata = cbdata; cb 895 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_INFO_CREATE(cb->info, 1); cb 896 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c if (NULL == cb->info) { cb 897 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_RELEASE(cb); cb 900 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_INFO_LOAD(&cb->info[0], PMIX_EVENT_CUSTOM_RANGE, leader, PMIX_PROC); cb 901 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c cb->ninfo = 1; cb 909 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c cb->info, cb->ninfo, cb 910 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c op_cbfunc, (void*)cb); cb 912 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_RELEASE(cb); cb 924 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c pmix_group_tracker_t *cb = (pmix_group_tracker_t*)cbdata; cb 926 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c cb->status = status; cb 927 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c if (NULL != cb->opcbfunc) { cb 928 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c cb->opcbfunc(status, cb->cbdata); cb 930 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_POST_OBJECT(cb); cb 931 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_WAKEUP_THREAD(&cb->lock); cb 936 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c pmix_group_tracker_t *cb = (pmix_group_tracker_t*)cbdata; cb 937 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_RELEASE(cb); cb 943 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c pmix_group_tracker_t *cb = (pmix_group_tracker_t*)cbdata; cb 989 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c if (NULL != cb->cbfunc) { cb 990 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c cb->cbfunc(ret, iptr, ninfo, cb->cbdata, relfn, cb); cb 992 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c } else if (NULL != cb->opcbfunc) { cb 993 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c cb->opcbfunc(ret, cb->cbdata); cb 996 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_RELEASE(cb); cb 1005 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c pmix_group_tracker_t *cb = (pmix_group_tracker_t*)cbdata; cb 1009 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c cb->status = status; cb 1012 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c cb->nresults = ninfo; cb 1013 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_INFO_CREATE(cb->results, cb->nresults); cb 1015 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_INFO_XFER(&cb->results[n], &info[n]); cb 1021 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_POST_OBJECT(cb); cb 1022 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c PMIX_WAKEUP_THREAD(&cb->lock); cb 72 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c pmix_cb_t *cb; cb 92 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c cb = PMIX_NEW(pmix_cb_t); cb 94 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c if (PMIX_SUCCESS != (rc = PMIx_Publish_nb(info, ninfo, op_cbfunc, cb))) { cb 96 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c PMIX_RELEASE(cb); cb 101 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c PMIX_WAIT_THREAD(&cb->lock); cb 102 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c rc = (pmix_status_t)cb->status; cb 103 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c PMIX_RELEASE(cb); cb 114 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c pmix_cb_t *cb; cb 181 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c cb = PMIX_NEW(pmix_cb_t); cb 182 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c cb->cbfunc.opfn = cbfunc; cb 183 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c cb->cbdata = cbdata; cb 187 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c msg, wait_cbfunc, (void*)cb); cb 190 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c PMIX_RELEASE(cb); cb 200 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c pmix_cb_t *cb; cb 236 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c cb = PMIX_NEW(pmix_cb_t); cb 237 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c cb->cbdata = (void*)pdata; cb 238 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c cb->nvals = ndata; cb 241 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c lookup_cbfunc, cb))) { cb 242 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c PMIX_RELEASE(cb); cb 248 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c PMIX_WAIT_THREAD(&cb->lock); cb 252 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c rc = cb->status; cb 253 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c PMIX_RELEASE(cb); cb 264 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c pmix_cb_t *cb; cb 350 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c cb = PMIX_NEW(pmix_cb_t); cb 351 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c cb->cbfunc.lookupfn = cbfunc; cb 352 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c cb->cbdata = cbdata; cb 356 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c msg, wait_lookup_cbfunc, (void*)cb); cb 359 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c PMIX_RELEASE(cb); cb 370 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c pmix_cb_t *cb; cb 392 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c cb = PMIX_NEW(pmix_cb_t); cb 395 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c if (PMIX_SUCCESS != (rc = PMIx_Unpublish_nb(keys, info, ninfo, op_cbfunc, cb))) { cb 396 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c PMIX_RELEASE(cb); cb 401 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c PMIX_WAIT_THREAD(&cb->lock); cb 402 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c rc = cb->status; cb 403 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c PMIX_RELEASE(cb); cb 415 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c pmix_cb_t *cb; cb 494 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c cb = PMIX_NEW(pmix_cb_t); cb 495 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c cb->cbfunc.opfn = cbfunc; cb 496 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c cb->cbdata = cbdata; cb 500 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c msg, wait_cbfunc, (void*)cb); cb 503 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c PMIX_RELEASE(cb); cb 513 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c pmix_cb_t *cb = (pmix_cb_t*)cbdata; cb 518 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c PMIX_ACQUIRE_OBJECT(cb); cb 544 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c if (NULL != cb->cbfunc.opfn) { cb 545 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c cb->cbfunc.opfn(rc, cb->cbdata); cb 547 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c PMIX_RELEASE(cb); cb 552 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c pmix_cb_t *cb = (pmix_cb_t*)cbdata; cb 554 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c cb->status = status; cb 555 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c PMIX_POST_OBJECT(cb); cb 556 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c PMIX_WAKEUP_THREAD(&cb->lock); cb 563 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c pmix_cb_t *cb = (pmix_cb_t*)cbdata; cb 569 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c PMIX_ACQUIRE_OBJECT(cb); cb 579 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c if (NULL == cb->cbfunc.lookupfn) { cb 581 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c PMIX_RELEASE(cb); cb 604 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c if (NULL != cb->cbfunc.lookupfn) { cb 605 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c cb->cbfunc.lookupfn(ret, NULL, 0, cb->cbdata); cb 607 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c PMIX_RELEASE(cb); cb 617 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c PMIX_RELEASE(cb); cb 634 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c if (NULL != cb->cbfunc.lookupfn) { cb 635 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c cb->cbfunc.lookupfn(rc, pdata, ndata, cb->cbdata); cb 644 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c PMIX_RELEASE(cb); cb 650 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c pmix_cb_t *cb = (pmix_cb_t*)cbdata; cb 651 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c pmix_pdata_t *tgt = (pmix_pdata_t*)cb->cbdata; cb 654 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c PMIX_ACQUIRE_OBJECT(cb); cb 655 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c cb->status = status; cb 659 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c for (j=0; j < cb->nvals; j++) { cb 665 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c PMIX_BFROPS_VALUE_XFER(cb->status, pmix_client_globals.myserver, &tgt[j].value, &pdata[i].value); cb 671 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c PMIX_POST_OBJECT(cb); cb 672 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c PMIX_WAKEUP_THREAD(&cb->lock); cb 70 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_spawn.c pmix_cb_t *cb; cb 96 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_spawn.c cb = PMIX_NEW(pmix_cb_t); cb 98 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_spawn.c if (PMIX_SUCCESS != (rc = PMIx_Spawn_nb(job_info, ninfo, apps, napps, spawn_cbfunc, cb))) { cb 99 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_spawn.c PMIX_RELEASE(cb); cb 104 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_spawn.c PMIX_WAIT_THREAD(&cb->lock); cb 105 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_spawn.c rc = cb->status; cb 107 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_spawn.c pmix_strncpy(nspace, cb->pname.nspace, PMIX_MAX_NSLEN); cb 109 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_spawn.c PMIX_RELEASE(cb); cb 121 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_spawn.c pmix_cb_t *cb; cb 259 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_spawn.c cb = PMIX_NEW(pmix_cb_t); cb 260 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_spawn.c cb->cbfunc.spawnfn = cbfunc; cb 261 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_spawn.c cb->cbdata = cbdata; cb 265 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_spawn.c msg, wait_cbfunc, (void*)cb); cb 268 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_spawn.c PMIX_RELEASE(cb); cb 279 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_spawn.c pmix_cb_t *cb = (pmix_cb_t*)cbdata; cb 285 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_spawn.c PMIX_ACQUIRE_OBJECT(cb); cb 336 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_spawn.c if (NULL != cb->cbfunc.spawnfn) { cb 337 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_spawn.c cb->cbfunc.spawnfn(ret, nspace, cb->cbdata); cb 339 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_spawn.c PMIX_RELEASE(cb); cb 344 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_spawn.c pmix_cb_t *cb = (pmix_cb_t*)cbdata; cb 346 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_spawn.c PMIX_ACQUIRE_OBJECT(cb); cb 347 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_spawn.c cb->status = status; cb 349 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_spawn.c cb->pname.nspace = strdup(nspace); cb 351 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_spawn.c PMIX_POST_OBJECT(cb); cb 352 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_spawn.c PMIX_WAKEUP_THREAD(&cb->lock); cb 121 opal/mca/pmix/pmix4x/pmix/src/common/pmix_control.c pmix_cb_t *cb = (pmix_cb_t*)cbdata; cb 122 opal/mca/pmix/pmix4x/pmix/src/common/pmix_control.c cb->status = status; cb 126 opal/mca/pmix/pmix4x/pmix/src/common/pmix_control.c PMIX_WAKEUP_THREAD(&cb->lock); cb 132 opal/mca/pmix/pmix4x/pmix/src/common/pmix_control.c pmix_cb_t cb; cb 149 opal/mca/pmix/pmix4x/pmix/src/common/pmix_control.c PMIX_CONSTRUCT(&cb, pmix_cb_t); cb 152 opal/mca/pmix/pmix4x/pmix/src/common/pmix_control.c acb, &cb))) { cb 153 opal/mca/pmix/pmix4x/pmix/src/common/pmix_control.c PMIX_DESTRUCT(&cb); cb 158 opal/mca/pmix/pmix4x/pmix/src/common/pmix_control.c PMIX_WAIT_THREAD(&cb.lock); cb 159 opal/mca/pmix/pmix4x/pmix/src/common/pmix_control.c rc = cb.status; cb 160 opal/mca/pmix/pmix4x/pmix/src/common/pmix_control.c PMIX_DESTRUCT(&cb); cb 175 opal/mca/pmix/pmix4x/pmix/src/common/pmix_control.c pmix_query_caddy_t *cb; cb 265 opal/mca/pmix/pmix4x/pmix/src/common/pmix_control.c cb = PMIX_NEW(pmix_query_caddy_t); cb 266 opal/mca/pmix/pmix4x/pmix/src/common/pmix_control.c cb->cbfunc = cbfunc; cb 267 opal/mca/pmix/pmix4x/pmix/src/common/pmix_control.c cb->cbdata = cbdata; cb 271 opal/mca/pmix/pmix4x/pmix/src/common/pmix_control.c msg, query_cbfunc, (void*)cb); cb 274 opal/mca/pmix/pmix4x/pmix/src/common/pmix_control.c PMIX_RELEASE(cb); cb 283 opal/mca/pmix/pmix4x/pmix/src/common/pmix_control.c pmix_cb_t cb; cb 300 opal/mca/pmix/pmix4x/pmix/src/common/pmix_control.c PMIX_CONSTRUCT(&cb, pmix_cb_t); cb 303 opal/mca/pmix/pmix4x/pmix/src/common/pmix_control.c acb, &cb))) { cb 304 opal/mca/pmix/pmix4x/pmix/src/common/pmix_control.c PMIX_DESTRUCT(&cb); cb 309 opal/mca/pmix/pmix4x/pmix/src/common/pmix_control.c PMIX_WAIT_THREAD(&cb.lock); cb 310 opal/mca/pmix/pmix4x/pmix/src/common/pmix_control.c rc = cb.status; cb 311 opal/mca/pmix/pmix4x/pmix/src/common/pmix_control.c PMIX_DESTRUCT(&cb); cb 326 opal/mca/pmix/pmix4x/pmix/src/common/pmix_control.c pmix_query_caddy_t *cb; cb 430 opal/mca/pmix/pmix4x/pmix/src/common/pmix_control.c cb = PMIX_NEW(pmix_query_caddy_t); cb 431 opal/mca/pmix/pmix4x/pmix/src/common/pmix_control.c cb->cbfunc = cbfunc; cb 432 opal/mca/pmix/pmix4x/pmix/src/common/pmix_control.c cb->cbdata = cbdata; cb 436 opal/mca/pmix/pmix4x/pmix/src/common/pmix_control.c msg, query_cbfunc, (void*)cb); cb 439 opal/mca/pmix/pmix4x/pmix/src/common/pmix_control.c PMIX_RELEASE(cb); cb 39 opal/mca/pmix/pmix4x/pmix/src/common/pmix_log.c pmix_cb_t *cb = (pmix_cb_t*)cbdata; cb 40 opal/mca/pmix/pmix4x/pmix/src/common/pmix_log.c cb->status = status; cb 41 opal/mca/pmix/pmix4x/pmix/src/common/pmix_log.c PMIX_WAKEUP_THREAD(&cb->lock); cb 68 opal/mca/pmix/pmix4x/pmix/src/common/pmix_log.c pmix_cb_t cb; cb 85 opal/mca/pmix/pmix4x/pmix/src/common/pmix_log.c PMIX_CONSTRUCT(&cb, pmix_cb_t); cb 87 opal/mca/pmix/pmix4x/pmix/src/common/pmix_log.c ndirs, opcbfunc, &cb))) { cb 88 opal/mca/pmix/pmix4x/pmix/src/common/pmix_log.c PMIX_DESTRUCT(&cb); cb 93 opal/mca/pmix/pmix4x/pmix/src/common/pmix_log.c PMIX_WAIT_THREAD(&cb.lock); cb 94 opal/mca/pmix/pmix4x/pmix/src/common/pmix_log.c rc = cb.status; cb 95 opal/mca/pmix/pmix4x/pmix/src/common/pmix_log.c PMIX_DESTRUCT(&cb); cb 144 opal/mca/pmix/pmix4x/pmix/src/common/pmix_query.c pmix_cb_t cb; cb 233 opal/mca/pmix/pmix4x/pmix/src/common/pmix_query.c PMIX_CONSTRUCT(&cb, pmix_cb_t); cb 234 opal/mca/pmix/pmix4x/pmix/src/common/pmix_query.c cb.copy = false; cb 239 opal/mca/pmix/pmix4x/pmix/src/common/pmix_query.c cb.proc = &pmix_globals.myid; cb 243 opal/mca/pmix/pmix4x/pmix/src/common/pmix_query.c PMIX_LOAD_NSPACE(cb.proc->nspace, pmix_globals.myid.nspace); cb 249 opal/mca/pmix/pmix4x/pmix/src/common/pmix_query.c cb.proc = &proc; cb 252 opal/mca/pmix/pmix4x/pmix/src/common/pmix_query.c cb.key = queries[n].keys[p]; cb 253 opal/mca/pmix/pmix4x/pmix/src/common/pmix_query.c PMIX_GDS_FETCH_KV(rc, pmix_globals.mypeer, &cb); cb 257 opal/mca/pmix/pmix4x/pmix/src/common/pmix_query.c PMIX_DESTRUCT(&cb); cb 261 opal/mca/pmix/pmix4x/pmix/src/common/pmix_query.c PMIX_LIST_FOREACH_SAFE(kv, kvnxt, &cb.kvs, pmix_kval_t) { cb 262 opal/mca/pmix/pmix4x/pmix/src/common/pmix_query.c pmix_list_remove_item(&cb.kvs, &kv->super); cb 265 opal/mca/pmix/pmix4x/pmix/src/common/pmix_query.c PMIX_DESTRUCT(&cb); cb 372 opal/mca/pmix/pmix4x/pmix/src/common/pmix_query.c pmix_cb_t *cb = (pmix_cb_t*)cbdata; cb 373 opal/mca/pmix/pmix4x/pmix/src/common/pmix_query.c cb->status = status; cb 377 opal/mca/pmix/pmix4x/pmix/src/common/pmix_query.c PMIX_WAKEUP_THREAD(&cb->lock); cb 383 opal/mca/pmix/pmix4x/pmix/src/common/pmix_query.c pmix_cb_t cb; cb 400 opal/mca/pmix/pmix4x/pmix/src/common/pmix_query.c PMIX_CONSTRUCT(&cb, pmix_cb_t); cb 402 opal/mca/pmix/pmix4x/pmix/src/common/pmix_query.c acb, &cb))) { cb 403 opal/mca/pmix/pmix4x/pmix/src/common/pmix_query.c PMIX_DESTRUCT(&cb); cb 408 opal/mca/pmix/pmix4x/pmix/src/common/pmix_query.c PMIX_WAIT_THREAD(&cb.lock); cb 409 opal/mca/pmix/pmix4x/pmix/src/common/pmix_query.c rc = cb.status; cb 410 opal/mca/pmix/pmix4x/pmix/src/common/pmix_query.c PMIX_DESTRUCT(&cb); cb 425 opal/mca/pmix/pmix4x/pmix/src/common/pmix_query.c pmix_query_caddy_t *cb; cb 504 opal/mca/pmix/pmix4x/pmix/src/common/pmix_query.c cb = PMIX_NEW(pmix_query_caddy_t); cb 505 opal/mca/pmix/pmix4x/pmix/src/common/pmix_query.c cb->cbfunc = cbfunc; cb 506 opal/mca/pmix/pmix4x/pmix/src/common/pmix_query.c cb->cbdata = cbdata; cb 510 opal/mca/pmix/pmix4x/pmix/src/common/pmix_query.c msg, query_cbfunc, (void*)cb); cb 513 opal/mca/pmix/pmix4x/pmix/src/common/pmix_query.c PMIX_RELEASE(cb); cb 119 opal/mca/pmix/pmix4x/pmix/src/common/pmix_security.c pmix_query_caddy_t *cb; cb 218 opal/mca/pmix/pmix4x/pmix/src/common/pmix_security.c cb = PMIX_NEW(pmix_query_caddy_t); cb 219 opal/mca/pmix/pmix4x/pmix/src/common/pmix_security.c cb->credcbfunc = cbfunc; cb 220 opal/mca/pmix/pmix4x/pmix/src/common/pmix_security.c cb->cbdata = cbdata; cb 224 opal/mca/pmix/pmix4x/pmix/src/common/pmix_security.c msg, getcbfunc, (void*)cb); cb 227 opal/mca/pmix/pmix4x/pmix/src/common/pmix_security.c PMIX_RELEASE(cb); cb 306 opal/mca/pmix/pmix4x/pmix/src/common/pmix_security.c pmix_query_caddy_t *cb; cb 410 opal/mca/pmix/pmix4x/pmix/src/common/pmix_security.c cb = PMIX_NEW(pmix_query_caddy_t); cb 411 opal/mca/pmix/pmix4x/pmix/src/common/pmix_security.c cb->validcbfunc = cbfunc; cb 412 opal/mca/pmix/pmix4x/pmix/src/common/pmix_security.c cb->cbdata = cbdata; cb 416 opal/mca/pmix/pmix4x/pmix/src/common/pmix_security.c msg, valid_cbfunc, (void*)cb); cb 419 opal/mca/pmix/pmix4x/pmix/src/common/pmix_security.c PMIX_RELEASE(cb); cb 98 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c pmix_cb_t *cb = (pmix_cb_t*)cbdata; cb 107 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (NULL != cb->cbfunc.opfn) { cb 108 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c cb->cbfunc.opfn(ret, cb->cbdata); cb 110 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_RELEASE(cb); cb 166 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c pmix_cb_t *cb; cb 280 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c cb = PMIX_NEW(pmix_cb_t); cb 281 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c cb->cbfunc.opfn = cbfunc; cb 282 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c cb->cbdata = cbdata; cb 290 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c msg, notify_event_cbfunc, cb); cb 293 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_RELEASE(cb); cb 262 opal/mca/pmix/pmix4x/pmix/src/include/types.h #define pmix_event_set(b, x, fd, fg, cb, arg) pmix_event_assign((x), (b), (fd), (fg), (event_callback_fn) (cb), (arg)) cb 281 opal/mca/pmix/pmix4x/pmix/src/include/types.h #define pmix_event_evtimer_new(b, cb, arg) pmix_event_new((b), -1, 0, (cb), (arg)) cb 285 opal/mca/pmix/pmix4x/pmix/src/include/types.h #define pmix_event_evtimer_set(b, x, cb, arg) pmix_event_assign((x), (b), -1, 0, (event_callback_fn) (cb), (arg)) cb 289 opal/mca/pmix/pmix4x/pmix/src/include/types.h #define pmix_event_signal_set(b, x, fd, cb, arg) pmix_event_assign((x), (b), (fd), EV_SIGNAL|EV_PERSIST, (event_callback_fn) (cb), (arg)) cb 2665 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c pmix_cb_t cb; cb 2671 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c PMIX_CONSTRUCT(&cb, pmix_cb_t); cb 2677 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c cb.proc = proc; cb 2678 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c cb.scope = PMIX_INTERNAL; cb 2679 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c cb.copy = false; cb 2681 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c PMIX_GDS_FETCH_KV(rc, pmix_globals.mypeer, &cb); cb 2690 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c PMIX_LIST_FOREACH(kv, &cb.kvs, pmix_kval_t) { cb 2735 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c PMIX_DESTRUCT(&cb); cb 417 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/test/pnet_test.c pmix_cb_t cb; cb 422 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/test/pnet_test.c PMIX_CONSTRUCT(&cb, pmix_cb_t); cb 424 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/test/pnet_test.c cb.key = strdup(PMIX_LOCAL_RANK); cb 426 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/test/pnet_test.c cb.copy = false; cb 428 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/test/pnet_test.c cb.scope = PMIX_SCOPE_UNDEF; cb 430 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/test/pnet_test.c cb.proc = (pmix_proc_t*)proc; cb 432 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/test/pnet_test.c PMIX_GDS_FETCH_KV(rc, pmix_globals.mypeer, &cb); cb 437 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/test/pnet_test.c PMIX_DESTRUCT(&cb); cb 441 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/test/pnet_test.c if (1 != pmix_list_get_size(&cb.kvs)) { cb 443 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/test/pnet_test.c PMIX_DESTRUCT(&cb); cb 446 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/test/pnet_test.c kv = (pmix_kval_t*)pmix_list_get_first(&cb.kvs); cb 449 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/test/pnet_test.c PMIX_DESTRUCT(&cb); cb 456 opal/mca/pmix/pmix4x/pmix/src/mca/pnet/test/pnet_test.c PMIX_DESTRUCT(&cb); cb 524 opal/mca/pmix/pmix4x/pmix/src/mca/preg/native/preg_native.c pmix_cb_t cb; cb 533 opal/mca/pmix/pmix4x/pmix/src/mca/preg/native/preg_native.c PMIX_CONSTRUCT(&cb, pmix_cb_t); cb 535 opal/mca/pmix/pmix4x/pmix/src/mca/preg/native/preg_native.c cb.key = strdup(nodename); cb 537 opal/mca/pmix/pmix4x/pmix/src/mca/preg/native/preg_native.c cb.copy = false; cb 539 opal/mca/pmix/pmix4x/pmix/src/mca/preg/native/preg_native.c cb.scope = PMIX_SCOPE_UNDEF; cb 543 opal/mca/pmix/pmix4x/pmix/src/mca/preg/native/preg_native.c cb.proc = &proc; cb 545 opal/mca/pmix/pmix4x/pmix/src/mca/preg/native/preg_native.c PMIX_GDS_FETCH_KV(rc, pmix_client_globals.myserver, &cb); cb 553 opal/mca/pmix/pmix4x/pmix/src/mca/preg/native/preg_native.c if (1 != pmix_list_get_size(&cb.kvs)) { cb 558 opal/mca/pmix/pmix4x/pmix/src/mca/preg/native/preg_native.c kv = (pmix_kval_t*)pmix_list_get_first(&cb.kvs); cb 594 opal/mca/pmix/pmix4x/pmix/src/mca/preg/native/preg_native.c if (NULL != cb.info) { cb 595 opal/mca/pmix/pmix4x/pmix/src/mca/preg/native/preg_native.c PMIX_INFO_FREE(cb.info, cb.ninfo); cb 597 opal/mca/pmix/pmix4x/pmix/src/mca/preg/native/preg_native.c if (NULL != cb.key) { cb 598 opal/mca/pmix/pmix4x/pmix/src/mca/preg/native/preg_native.c free(cb.key); cb 599 opal/mca/pmix/pmix4x/pmix/src/mca/preg/native/preg_native.c cb.key = NULL; cb 601 opal/mca/pmix/pmix4x/pmix/src/mca/preg/native/preg_native.c PMIX_DESTRUCT(&cb); cb 611 opal/mca/pmix/pmix4x/pmix/src/mca/preg/native/preg_native.c pmix_cb_t cb; cb 616 opal/mca/pmix/pmix4x/pmix/src/mca/preg/native/preg_native.c PMIX_CONSTRUCT(&cb, pmix_cb_t); cb 623 opal/mca/pmix/pmix4x/pmix/src/mca/preg/native/preg_native.c PMIX_INFO_CREATE(cb.info, 1); cb 624 opal/mca/pmix/pmix4x/pmix/src/mca/preg/native/preg_native.c if (NULL == cb.info) { cb 625 opal/mca/pmix/pmix4x/pmix/src/mca/preg/native/preg_native.c PMIX_DESTRUCT(&cb); cb 628 opal/mca/pmix/pmix4x/pmix/src/mca/preg/native/preg_native.c cb.ninfo = 1; cb 629 opal/mca/pmix/pmix4x/pmix/src/mca/preg/native/preg_native.c PMIX_INFO_LOAD(&cb.info[0], PMIX_NSPACE, nspace, PMIX_STRING); cb 632 opal/mca/pmix/pmix4x/pmix/src/mca/preg/native/preg_native.c cb.key = PMIX_NODE_MAP; cb 634 opal/mca/pmix/pmix4x/pmix/src/mca/preg/native/preg_native.c cb.copy = false; cb 636 opal/mca/pmix/pmix4x/pmix/src/mca/preg/native/preg_native.c cb.scope = PMIX_SCOPE_UNDEF; cb 641 opal/mca/pmix/pmix4x/pmix/src/mca/preg/native/preg_native.c cb.proc = &proc; cb 643 opal/mca/pmix/pmix4x/pmix/src/mca/preg/native/preg_native.c PMIX_GDS_FETCH_KV(rc, pmix_client_globals.myserver, &cb); cb 649 opal/mca/pmix/pmix4x/pmix/src/mca/preg/native/preg_native.c if (1 != pmix_list_get_size(&cb.kvs)) { cb 654 opal/mca/pmix/pmix4x/pmix/src/mca/preg/native/preg_native.c kv = (pmix_kval_t*)pmix_list_get_first(&cb.kvs); cb 669 opal/mca/pmix/pmix4x/pmix/src/mca/preg/native/preg_native.c if (NULL != cb.info) { cb 670 opal/mca/pmix/pmix4x/pmix/src/mca/preg/native/preg_native.c PMIX_INFO_FREE(cb.info, cb.ninfo); cb 809 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c pmix_cb_t cb; cb 879 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_CONSTRUCT(&cb, pmix_cb_t); cb 880 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c cb.proc = &proc; cb 881 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c cb.scope = PMIX_REMOTE; cb 882 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c cb.copy = true; cb 883 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_GDS_FETCH_KV(rc, peer, &cb); cb 891 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_DESTRUCT(&cb); cb 896 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_LIST_FOREACH(kv, &cb.kvs, pmix_kval_t) { cb 900 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_DESTRUCT(&cb); cb 913 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_DESTRUCT(&cb); cb 920 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_DESTRUCT(&cb); cb 1305 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c pmix_cb_t cb; cb 1343 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_CONSTRUCT(&cb, pmix_cb_t); cb 1344 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c cb.proc = &cd->proc; cb 1345 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c cb.scope = PMIX_REMOTE; cb 1346 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c cb.copy = true; cb 1348 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_GDS_FETCH_KV(rc, pmix_globals.mypeer, &cb); cb 1351 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_LIST_FOREACH(kv, &cb.kvs, pmix_kval_t) { cb 1355 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_DESTRUCT(&cb); cb 1360 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_DESTRUCT(&cb); cb 1395 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_CONSTRUCT(&cb, pmix_cb_t); cb 1396 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c cb.proc = &cd->proc; cb 1397 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c cb.scope = PMIX_REMOTE; cb 1398 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c cb.copy = true; cb 1399 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_GDS_FETCH_KV(rc, pmix_globals.mypeer, &cb); cb 1403 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_LIST_FOREACH(kv, &cb.kvs, pmix_kval_t) { cb 1407 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_DESTRUCT(&cb); cb 1414 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_DESTRUCT(&cb); cb 2154 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c pmix_cb_t cb; cb 2183 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_CONSTRUCT(&cb, pmix_cb_t); cb 2184 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c cb.proc = &proc; cb 2185 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c cb.scope = PMIX_SCOPE_UNDEF; cb 2186 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c cb.copy = false; cb 2187 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_GDS_FETCH_KV(rc, pmix_globals.mypeer, &cb); cb 2189 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_LIST_FOREACH(kv, &cb.kvs, pmix_kval_t) { cb 2194 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_DESTRUCT(&cb); cb 2198 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_DESTRUCT(&cb); cb 2510 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c pmix_cb_t cb; cb 2578 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_CONSTRUCT(&cb, pmix_cb_t); cb 2582 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c cb.proc = &proc; cb 2583 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c cb.scope = PMIX_SCOPE_UNDEF; cb 2584 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c cb.copy = false; cb 2585 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_GDS_FETCH_KV(rc, cd->peer, &cb); cb 2589 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_DESTRUCT(&cb); cb 2599 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_DESTRUCT(&cb); cb 2602 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_LIST_FOREACH(kptr, &cb.kvs, pmix_kval_t) { cb 2608 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_DESTRUCT(&cb); cb 2612 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_DESTRUCT(&cb); cb 2620 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_DESTRUCT(&cb); cb 2630 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_DESTRUCT(&cb); cb 131 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c pmix_cb_t cb; cb 310 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c PMIX_CONSTRUCT(&cb, pmix_cb_t); cb 315 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c cb.proc = &proc; cb 316 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c cb.scope = PMIX_SCOPE_UNDEF; cb 317 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c cb.copy = false; cb 318 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c PMIX_GDS_FETCH_KV(rc, peer, &cb); cb 320 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c PMIX_DESTRUCT(&cb); cb 325 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c PMIX_GDS_ASSEMB_KVS_REQ(rc, peer, &proc, &cb.kvs, &pkt, cd); cb 328 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c PMIX_DESTRUCT(&cb); cb 340 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c PMIX_DESTRUCT(&cb); cb 600 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c pmix_cb_t cb; cb 665 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c PMIX_CONSTRUCT(&cb, pmix_cb_t); cb 669 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c cb.proc = &proc; cb 670 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c cb.scope = PMIX_INTERNAL; cb 671 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c cb.copy = false; cb 672 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c PMIX_GDS_FETCH_KV(rc, pmix_globals.mypeer, &cb); cb 676 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c PMIX_GDS_ASSEMB_KVS_REQ(rc, cd->peer, &proc, &cb.kvs, &pkt, cd); cb 681 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c PMIX_DESTRUCT(&cb); cb 696 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c PMIX_DESTRUCT(&cb); cb 710 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c PMIX_DESTRUCT(&cb); cb 714 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c PMIX_DESTRUCT(&cb); cb 733 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c PMIX_CONSTRUCT(&cb, pmix_cb_t); cb 737 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c cb.proc = &proc; cb 738 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c cb.scope = scope; cb 739 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c cb.copy = false; cb 740 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c PMIX_GDS_FETCH_KV(rc, peer, &cb); cb 745 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c PMIX_GDS_ASSEMB_KVS_REQ(rc, cd->peer, &proc, &cb.kvs, &pkt, cd); cb 750 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c PMIX_DESTRUCT(&cb); cb 763 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c PMIX_DESTRUCT(&cb); cb 772 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c PMIX_DESTRUCT(&cb); cb 784 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c PMIX_DESTRUCT(&cb); cb 789 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c PMIX_DESTRUCT(&cb); cb 887 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c pmix_cb_t cb; cb 966 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c PMIX_CONSTRUCT(&cb, pmix_cb_t); cb 967 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c PMIX_PROC_CREATE(cb.proc, 1); cb 968 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c if (NULL == cb.proc) { cb 970 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c PMIX_DESTRUCT(&cb); cb 973 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c pmix_strncpy(cb.proc->nspace, nm->ns->nspace, PMIX_MAX_NSLEN); cb 974 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c cb.proc->rank = PMIX_RANK_WILDCARD; cb 975 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c cb.scope = PMIX_INTERNAL; cb 976 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c cb.copy = false; cb 977 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c PMIX_GDS_FETCH_KV(rc, pmix_globals.mypeer, &cb); cb 980 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c PMIX_DESTRUCT(&cb); cb 983 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c PMIX_LIST_FOREACH(kv, &cb.kvs, pmix_kval_t) { cb 990 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c PMIX_DESTRUCT(&cb); cb 169 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_cb_t cb; cb 261 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_CONSTRUCT(&cb, pmix_cb_t); cb 262 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c cb.proc = &proc; cb 263 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c cb.scope = PMIX_REMOTE; cb 264 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c cb.copy = true; cb 265 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_GDS_FETCH_KV(rc, pmix_globals.mypeer, &cb); cb 269 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_LIST_FOREACH(kp, &cb.kvs, pmix_kval_t) { cb 276 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_DESTRUCT(&cb); cb 526 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_cb_t cb; cb 567 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_CONSTRUCT(&cb, pmix_cb_t); cb 568 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c cb.proc = &pcs; cb 569 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c cb.scope = PMIX_REMOTE; cb 570 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c cb.copy = true; cb 571 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_GDS_FETCH_KV(rc, pmix_globals.mypeer, &cb); cb 574 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_LIST_FOREACH(kv, &cb.kvs, pmix_kval_t) { cb 642 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_CONSTRUCT(&cb, pmix_cb_t); cb 643 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c cb.proc = &pcs; cb 644 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c cb.scope = PMIX_REMOTE; cb 645 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c cb.copy = true; cb 646 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_GDS_FETCH_KV(rc, pmix_globals.mypeer, &cb); cb 665 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_DESTRUCT(&cb); cb 677 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_DESTRUCT(&cb); cb 683 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_LIST_FOREACH(kv, &cb.kvs, pmix_kval_t) { cb 688 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_DESTRUCT(&cb); cb 701 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_DESTRUCT(&cb); cb 2513 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_cb_t cb; cb 2594 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_CONSTRUCT(&cb, pmix_cb_t); cb 2595 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c cb.copy = false; cb 2600 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c cb.proc = &pmix_globals.myid; cb 2604 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_LOAD_NSPACE(cb.proc->nspace, pmix_globals.myid.nspace); cb 2610 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c cb.proc = &proc; cb 2613 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c cb.key = cd->queries[n].keys[p]; cb 2614 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_GDS_FETCH_KV(rc, pmix_globals.mypeer, &cb); cb 2618 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_DESTRUCT(&cb); cb 2622 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_LIST_FOREACH_SAFE(kv, kvnxt, &cb.kvs, pmix_kval_t) { cb 2623 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_list_remove_item(&cb.kvs, &kv->super); cb 2626 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c PMIX_DESTRUCT(&cb); cb 235 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c pmix_cb_t *cb = (pmix_cb_t*)cbdata; cb 242 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c cb->status = PMIX_ERROR; cb 243 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c PMIX_POST_OBJECT(cb); cb 244 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c PMIX_WAKEUP_THREAD(&cb->lock); cb 249 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c PMIX_GDS_STORE_JOB_INFO(cb->status, cb 252 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c cb->status = PMIX_SUCCESS; cb 253 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c PMIX_POST_OBJECT(cb); cb 254 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c PMIX_WAKEUP_THREAD(&cb->lock); cb 274 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c pmix_cb_t cb; cb 721 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c PMIX_CONSTRUCT(&cb, pmix_cb_t); cb 723 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c req, job_data, (void*)&cb); cb 729 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c PMIX_WAIT_THREAD(&cb.lock); cb 730 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c rc = cb.status; cb 731 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c PMIX_DESTRUCT(&cb); cb 742 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c pmix_cb_t cb; cb 743 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c PMIX_CONSTRUCT(&cb, pmix_cb_t); cb 746 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c cb.proc = &wildcard; cb 747 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c cb.copy = true; cb 748 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c PMIX_GDS_FETCH_KV(rc, pmix_globals.mypeer, &cb); cb 266 opal/mca/pmix/pmix4x/pmix/test/server_callbacks.c release_cbdata *cb = (release_cbdata*)arg; cb 267 opal/mca/pmix/pmix4x/pmix/test/server_callbacks.c if (NULL != cb->cbfunc) { cb 268 opal/mca/pmix/pmix4x/pmix/test/server_callbacks.c cb->cbfunc(cb->status, "foobar", cb->cbdata); cb 270 opal/mca/pmix/pmix4x/pmix/test/server_callbacks.c free(cb); cb 291 opal/mca/pmix/pmix4x/pmix/test/server_callbacks.c release_cbdata *cb = malloc(sizeof(release_cbdata)); cb 293 opal/mca/pmix/pmix4x/pmix/test/server_callbacks.c cb->status = PMIX_SUCCESS; cb 294 opal/mca/pmix/pmix4x/pmix/test/server_callbacks.c cb->cbfunc = cbfunc; cb 295 opal/mca/pmix/pmix4x/pmix/test/server_callbacks.c cb->cbdata = cbdata; cb 298 opal/mca/pmix/pmix4x/pmix/test/server_callbacks.c PMIx_server_register_nspace("foobar", napps, NULL, 0, release_cb, (void*)cb); cb 22 opal/mca/pmix/pmix4x/pmix/test/test_cd.c cd_cbdata *cb = (cd_cbdata*)cbdata; cb 24 opal/mca/pmix/pmix4x/pmix/test/test_cd.c cb->status = status; cb 25 opal/mca/pmix/pmix4x/pmix/test/test_cd.c cb->in_progress = 0; cb 30 opal/mca/pmix/pmix4x/pmix/test/test_cd.c cd_cbdata *cb = (cd_cbdata*)cbdata; cb 32 opal/mca/pmix/pmix4x/pmix/test/test_cd.c cb->status = status; cb 33 opal/mca/pmix/pmix4x/pmix/test/test_cd.c cb->in_progress = 0; cb 17 opal/mca/pmix/pmix4x/pmix/test/test_fence.c get_cbdata *cb = (get_cbdata*)cbdata; cb 18 opal/mca/pmix/pmix4x/pmix/test/test_fence.c PMIX_ACQUIRE_OBJECT(cb); cb 20 opal/mca/pmix/pmix4x/pmix/test/test_fence.c pmix_value_xfer(cb->kv, kv); cb 22 opal/mca/pmix/pmix4x/pmix/test/test_fence.c cb->status = status; cb 23 opal/mca/pmix/pmix4x/pmix/test/test_fence.c PMIX_POST_OBJECT(cb); cb 24 opal/mca/pmix/pmix4x/pmix/test/test_fence.c cb->in_progress = 0; cb 23 opal/mca/pmix/pmix4x/pmix/test/test_internal.c get_cbdata *cb = (get_cbdata*)cbdata; cb 25 opal/mca/pmix/pmix4x/pmix/test/test_internal.c pmix_value_xfer(cb->kv, kv); cb 27 opal/mca/pmix/pmix4x/pmix/test/test_internal.c cb->in_progress = 0; cb 28 opal/mca/pmix/pmix4x/pmix/test/test_internal.c cb->status = status; cb 34 opal/mca/pmix/pmix4x/pmix/test/test_publish.c lookup_cbdata *cb = (lookup_cbdata*)cbdata; cb 35 opal/mca/pmix/pmix4x/pmix/test/test_publish.c pmix_pdata_t *tgt = cb->pdata; cb 39 opal/mca/pmix/pmix4x/pmix/test/test_publish.c for (j=0; j < cb->npdata; j++) { cb 49 opal/mca/pmix/pmix4x/pmix/test/test_publish.c cb->in_progress = 0; cb 22 opal/mca/pmix/pmix4x/pmix/test/test_replace.c get_cbdata *cb = (get_cbdata*)cbdata; cb 24 opal/mca/pmix/pmix4x/pmix/test/test_replace.c pmix_value_xfer(cb->kv, kv); cb 26 opal/mca/pmix/pmix4x/pmix/test/test_replace.c cb->in_progress = 0; cb 27 opal/mca/pmix/pmix4x/pmix/test/test_replace.c cb->status = status; cb 24 opal/mca/pmix/pmix4x/pmix/test/test_spawn.c spawn_cbdata *cb = (spawn_cbdata*)cbdata; cb 26 opal/mca/pmix/pmix4x/pmix/test/test_spawn.c strncpy(cb->nspace, nspace, strlen(nspace)+1); cb 27 opal/mca/pmix/pmix4x/pmix/test/test_spawn.c cb->in_progress = 0; cb 163 opal/mca/pmix/pmix4x/pmix4x.h #define OPAL_PMIX_OP_THREADSHIFT(e, fn, cb, cd) \ cb 168 opal/mca/pmix/pmix4x/pmix4x.h _cd->opcbfunc = (cb); \ cb 176 opal/mca/pmix/pmix4x/pmix4x.h #define OPAL_PMIX_THREADSHIFT(e, i, eh, fn, cb, cd) \ cb 183 opal/mca/pmix/pmix4x/pmix4x.h _cd->cbfunc = (cb); \ cb 191 opal/mca/pmix/pmix4x/pmix4x.h #define OPAL_PMIX_NOTIFY_THREADSHIFT(s, sr, r, i, fn, cb, cd) \ cb 199 opal/mca/pmix/pmix4x/pmix4x.h _cd->opcbfunc = (cb); \ cb 207 opal/mca/pmix/pmix4x/pmix4x.h #define OPAL_PMIX2X_THREADSHIFT(p, cb) \ cb 210 opal/mca/pmix/pmix4x/pmix4x.h -1, EV_WRITE, (cb), (p)); \ cb 98 opal/runtime/opal_progress.c static int _opal_progress_unregister (opal_progress_callback_t cb, volatile opal_progress_callback_t *callback_array, cb 370 opal/runtime/opal_progress.c static int opal_progress_find_cb (opal_progress_callback_t cb, volatile opal_progress_callback_t *cbs, cb 374 opal/runtime/opal_progress.c if (cbs[i] == cb) { cb 382 opal/runtime/opal_progress.c static int _opal_progress_register (opal_progress_callback_t cb, volatile opal_progress_callback_t **cbs, cb 387 opal/runtime/opal_progress.c if (OPAL_ERR_NOT_FOUND != opal_progress_find_cb (cb, *cbs, *cbs_len)) { cb 420 opal/runtime/opal_progress.c cbs[0][*cbs_len] = cb; cb 428 opal/runtime/opal_progress.c int opal_progress_register (opal_progress_callback_t cb) cb 434 opal/runtime/opal_progress.c (void) _opal_progress_unregister (cb, callbacks_lp, &callbacks_lp_len); cb 436 opal/runtime/opal_progress.c ret = _opal_progress_register (cb, &callbacks, &callbacks_size, &callbacks_len); cb 443 opal/runtime/opal_progress.c int opal_progress_register_lp (opal_progress_callback_t cb) cb 449 opal/runtime/opal_progress.c (void) _opal_progress_unregister (cb, callbacks, &callbacks_len); cb 451 opal/runtime/opal_progress.c ret = _opal_progress_register (cb, &callbacks_lp, &callbacks_lp_size, &callbacks_lp_len); cb 458 opal/runtime/opal_progress.c static int _opal_progress_unregister (opal_progress_callback_t cb, volatile opal_progress_callback_t *callback_array, cb 461 opal/runtime/opal_progress.c int ret = opal_progress_find_cb (cb, callback_array, *callback_array_len); cb 482 opal/runtime/opal_progress.c int opal_progress_unregister (opal_progress_callback_t cb) cb 488 opal/runtime/opal_progress.c ret = _opal_progress_unregister (cb, callbacks, &callbacks_len); cb 493 opal/runtime/opal_progress.c ret = _opal_progress_unregister (cb, callbacks_lp, &callbacks_lp_len); cb 156 opal/runtime/opal_progress.h OPAL_DECLSPEC int opal_progress_register(opal_progress_callback_t cb); cb 158 opal/runtime/opal_progress.h OPAL_DECLSPEC int opal_progress_register_lp (opal_progress_callback_t cb); cb 167 opal/runtime/opal_progress.h OPAL_DECLSPEC int opal_progress_unregister(opal_progress_callback_t cb); cb 54 orte/mca/state/state_types.h typedef void (*orte_state_cbfunc_t)(int fd, short args, void* cb); cb 144 orte/orted/pmix/pmix_server_internal.h #define ORTE_PMIX_OPERATION(p, i, fn, cf, cb) \ cb 151 orte/orted/pmix/pmix_server_internal.h _cd->cbdata = (cb); \ cb 159 orte/orted/pmix/pmix_server_internal.h #define ORTE_PMIX_THREADSHIFT(p, s, st, m, pl, fn, cf, cb) \ cb 170 orte/orted/pmix/pmix_server_internal.h _cd->cbdata = (cb); \ cb 56 orte/runtime/orte_wait.h typedef void (*orte_wait_cbfunc_t)(int fd, short args, void* cb);