ctx_rec 840 opal/mca/common/ucx/common_ucx_wpool.c _tlocal_ctx_record_cleanup(_tlocal_ctx_t *ctx_rec) ctx_rec 842 opal/mca/common/ucx/common_ucx_wpool.c if (NULL == ctx_rec->gctx) { ctx_rec 846 opal/mca/common/ucx/common_ucx_wpool.c if (ctx_rec->refcnt > 0) { ctx_rec 853 opal/mca/common/ucx/common_ucx_wpool.c _common_ucx_wpctx_remove(ctx_rec->gctx, ctx_rec->winfo); ctx_rec 856 opal/mca/common/ucx/common_ucx_wpool.c memset(ctx_rec, 0, sizeof(*ctx_rec)); ctx_rec 922 opal/mca/common/ucx/common_ucx_wpool.c static int _tlocal_ctx_connect(_tlocal_ctx_t *ctx_rec, int target) ctx_rec 925 opal/mca/common/ucx/common_ucx_wpool.c opal_common_ucx_winfo_t *winfo = ctx_rec->winfo; ctx_rec 926 opal/mca/common/ucx/common_ucx_wpool.c opal_common_ucx_ctx_t *gctx = ctx_rec->gctx; ctx_rec 982 opal/mca/common/ucx/common_ucx_wpool.c assert(mem_rec->ctx_rec != NULL); ctx_rec 983 opal/mca/common/ucx/common_ucx_wpool.c OPAL_ATOMIC_ADD_FETCH32(&mem_rec->ctx_rec->refcnt, -1); ctx_rec 984 opal/mca/common/ucx/common_ucx_wpool.c assert(mem_rec->ctx_rec->refcnt >= 0); ctx_rec 995 opal/mca/common/ucx/common_ucx_wpool.c _tlocal_ctx_t *ctx_rec = NULL; ctx_rec 1025 opal/mca/common/ucx/common_ucx_wpool.c ctx_rec = _tlocal_ctx_search(tls, mem->ctx); ctx_rec 1026 opal/mca/common/ucx/common_ucx_wpool.c if (NULL == ctx_rec) { ctx_rec 1031 opal/mca/common/ucx/common_ucx_wpool.c tls->mem_tbl[free_idx]->ctx_rec = ctx_rec; ctx_rec 1032 opal/mca/common/ucx/common_ucx_wpool.c OPAL_ATOMIC_ADD_FETCH32(&ctx_rec->refcnt, 1); ctx_rec 1034 opal/mca/common/ucx/common_ucx_wpool.c tls->mem_tbl[free_idx]->mem->worker = ctx_rec->winfo; ctx_rec 1040 opal/mca/common/ucx/common_ucx_wpool.c tls->mem_tbl[free_idx]->mem_tls_ptr->winfo = ctx_rec->winfo; ctx_rec 1083 opal/mca/common/ucx/common_ucx_wpool.c _tlocal_ctx_t *ctx_rec = NULL; ctx_rec 1093 opal/mca/common/ucx/common_ucx_wpool.c ctx_rec = _tlocal_ctx_search(tls, mem->ctx); ctx_rec 1095 opal/mca/common/ucx/common_ucx_wpool.c if (OPAL_UNLIKELY(NULL == ctx_rec)) { ctx_rec 1096 opal/mca/common/ucx/common_ucx_wpool.c ctx_rec = _tlocal_add_ctx(tls, mem->ctx); ctx_rec 1097 opal/mca/common/ucx/common_ucx_wpool.c if (NULL == ctx_rec) { ctx_rec 1101 opal/mca/common/ucx/common_ucx_wpool.c winfo = ctx_rec->winfo; ctx_rec 1105 opal/mca/common/ucx/common_ucx_wpool.c rc = _tlocal_ctx_connect(ctx_rec, target); ctx_rec 23 opal/mca/common/ucx/common_ucx_wpool_int.h _tlocal_ctx_t *ctx_rec; ctx_rec 63 opal/mca/common/ucx/common_ucx_wpool_int.h static int _tlocal_ctx_record_cleanup(_tlocal_ctx_t *ctx_rec);