btl 76 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c int mca_btl_tcp2_add_procs( struct mca_btl_base_module_t* btl, btl 82 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c mca_btl_tcp2_module_t* tcp_btl = (mca_btl_tcp2_module_t*)btl; btl 148 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c int mca_btl_tcp2_del_procs(struct mca_btl_base_module_t* btl, btl 153 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c mca_btl_tcp2_module_t* tcp_btl = (mca_btl_tcp2_module_t*)btl; btl 177 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c struct mca_btl_base_module_t* btl, btl 185 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c if(size <= btl->btl_eager_limit) { btl 187 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c } else if (size <= btl->btl_max_send_size) { btl 203 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c frag->btl = (mca_btl_tcp_module_t*)btl; btl 214 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c struct mca_btl_base_module_t* btl, btl 230 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c struct mca_btl_base_module_t* btl, btl 252 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c if (max_data+reserve <= btl->btl_eager_limit) { btl 279 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c mca_btl_tcp2_free(btl, &frag->base); btl 292 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c mca_btl_tcp2_free(btl, &frag->base); btl 326 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c struct mca_btl_base_module_t* btl, btl 367 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c int mca_btl_tcp2_send( struct mca_btl_base_module_t* btl, btl 372 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c mca_btl_tcp2_module_t* tcp_btl = (mca_btl_tcp2_module_t*) btl; btl 376 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c frag->btl = tcp_btl; btl 407 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c int mca_btl_tcp2_put( mca_btl_base_module_t* btl, btl 411 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c mca_btl_tcp2_module_t* tcp_btl = (mca_btl_tcp2_module_t*) btl; btl 415 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c frag->btl = tcp_btl; btl 450 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c mca_btl_base_module_t* btl, btl 454 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c mca_btl_tcp2_module_t* tcp_btl = (mca_btl_tcp2_module_t*) btl; btl 458 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c frag->btl = tcp_btl; btl 482 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c int mca_btl_tcp2_finalize(struct mca_btl_base_module_t* btl) btl 484 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c mca_btl_tcp2_module_t* tcp_btl = (mca_btl_tcp2_module_t*) btl; btl 506 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c mca_btl_tcp_module_t* btl = (mca_btl_tcp_module_t*)base_btl; btl 512 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c ORTE_NAME_PRINT(ORTE_PROC_MY_NAME), (void*)btl, btl->tcp_ifkindex, btl 514 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c btl->tcp_bytes_sent, btl->btl_bytes_recv, btl 516 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c btl->super.btl_latency, btl->super.btl_bandwidth); btl 522 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c for(item = opal_list_get_first(&btl->tcp_endpoints); btl 523 contrib/build-mca-comps-outside-of-tree/btl_tcp2.c item != opal_list_get_end(&btl->tcp_endpoints); btl 172 contrib/build-mca-comps-outside-of-tree/btl_tcp2.h struct mca_btl_base_module_t* btl btl 189 contrib/build-mca-comps-outside-of-tree/btl_tcp2.h struct mca_btl_base_module_t* btl, btl 208 contrib/build-mca-comps-outside-of-tree/btl_tcp2.h struct mca_btl_base_module_t* btl, btl 225 contrib/build-mca-comps-outside-of-tree/btl_tcp2.h struct mca_btl_base_module_t* btl, btl 241 contrib/build-mca-comps-outside-of-tree/btl_tcp2.h struct mca_btl_base_module_t* btl, btl 256 contrib/build-mca-comps-outside-of-tree/btl_tcp2.h struct mca_btl_base_module_t* btl, btl 271 contrib/build-mca-comps-outside-of-tree/btl_tcp2.h struct mca_btl_base_module_t* btl, btl 286 contrib/build-mca-comps-outside-of-tree/btl_tcp2.h struct mca_btl_base_module_t* btl, btl 305 contrib/build-mca-comps-outside-of-tree/btl_tcp2.h struct mca_btl_base_module_t* btl, btl 316 contrib/build-mca-comps-outside-of-tree/btl_tcp2.h struct mca_btl_base_module_t* btl, btl 348 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c struct mca_btl_tcp2_module_t* btl; btl 353 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c btl = (struct mca_btl_tcp2_module_t *)malloc(sizeof(mca_btl_tcp2_module_t)); btl 354 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c if(NULL == btl) btl 356 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c memcpy(btl, &mca_btl_tcp2_module, sizeof(mca_btl_tcp2_module)); btl 357 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c OBJ_CONSTRUCT(&btl->tcp_endpoints, opal_list_t); btl 358 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c mca_btl_tcp2_component.tcp_btls[mca_btl_tcp2_component.tcp_num_btls++] = btl; btl 361 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c btl->tcp_ifkindex = (uint16_t) if_kindex; btl 363 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c btl->tcp_bytes_recv = 0; btl 364 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c btl->tcp_bytes_sent = 0; btl 365 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c btl->tcp_send_handler = 0; btl 370 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c btl->super.btl_bandwidth = mca_btl_tcp2_param_register_int(param, NULL, btl->super.btl_bandwidth); btl 374 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c btl->super.btl_latency = mca_btl_tcp2_param_register_int(param, NULL, btl->super.btl_latency); btl 376 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c btl->super.btl_bandwidth >>= 1; btl 377 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c btl->super.btl_latency <<= 1; btl 382 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c btl->super.btl_bandwidth = mca_btl_tcp2_param_register_int(param, NULL, btl->super.btl_bandwidth); btl 386 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c btl->super.btl_latency = mca_btl_tcp2_param_register_int(param, NULL, btl->super.btl_latency); btl 389 contrib/build-mca-comps-outside-of-tree/btl_tcp2_component.c btl->super.btl_bandwidth, btl->super.btl_latency)); btl 59 contrib/build-mca-comps-outside-of-tree/btl_tcp2_frag.h struct mca_btl_tcp2_module_t* btl; btl 87 ompi/mca/bml/base/bml_base_btl.c struct mca_btl_base_module_t* btl, btl 99 ompi/mca/bml/base/bml_base_btl.c des->des_cbfunc(btl,ep,des,status); btl 116 ompi/mca/bml/base/bml_base_btl.c des->des_cbfunc(bml_btl->btl, bml_btl->btl_endpoint, des, OMPI_SUCCESS); btl 135 ompi/mca/bml/base/bml_base_btl.c return bml_btl->btl_send( bml_btl->btl, btl 62 ompi/mca/bml/bml.h struct mca_btl_base_module_t *btl; /**< BTL module */ btl 134 ompi/mca/bml/bml.h struct mca_btl_base_module_t* btl ) btl 139 ompi/mca/bml/bml.h if( array->bml_btls[i].btl == btl ) { btl 205 ompi/mca/bml/bml.h mca_bml_base_btl_array_t* array, struct mca_btl_base_module_t* btl) btl 209 ompi/mca/bml/bml.h if(array->bml_btls[i].btl == btl) { btl 241 ompi/mca/bml/bml.h mca_btl_base_module_t* btl = bml_btl->btl; btl 242 ompi/mca/bml/bml.h *des = btl->btl_alloc(btl, bml_btl->btl_endpoint, order, size, flags); btl 248 ompi/mca/bml/bml.h mca_btl_base_module_t* btl = bml_btl->btl; btl 250 ompi/mca/bml/bml.h btl->btl_free( btl, des ); btl 270 ompi/mca/bml/bml.h mca_btl_base_module_t* btl = bml_btl->btl; btl 273 ompi/mca/bml/bml.h rc = btl->btl_send(btl, bml_btl->btl_endpoint, des, tag); btl 286 ompi/mca/bml/bml.h mca_btl_base_module_t* btl = bml_btl->btl; btl 289 ompi/mca/bml/bml.h return btl->btl_send(btl, bml_btl->btl_endpoint, des, tag); btl 302 ompi/mca/bml/bml.h mca_btl_base_module_t* btl = bml_btl->btl; btl 303 ompi/mca/bml/bml.h return btl->btl_sendi(btl, bml_btl->btl_endpoint, btl 313 ompi/mca/bml/bml.h mca_btl_base_module_t* btl = bml_btl->btl; btl 315 ompi/mca/bml/bml.h return btl->btl_put( btl, bml_btl->btl_endpoint, local_address, remote_address, local_handle, btl 324 ompi/mca/bml/bml.h mca_btl_base_module_t* btl = bml_btl->btl; btl 326 ompi/mca/bml/bml.h return btl->btl_get( btl, bml_btl->btl_endpoint, local_address, remote_address, local_handle, btl 339 ompi/mca/bml/bml.h mca_btl_base_module_t* btl = bml_btl->btl; btl 341 ompi/mca/bml/bml.h *des = btl->btl_prepare_src( btl, bml_btl->btl_endpoint, conv, btl 352 ompi/mca/bml/bml.h mca_btl_base_module_t* btl = bml_btl->btl; btl 354 ompi/mca/bml/bml.h *handle = btl->btl_register_mem (btl, bml_btl->btl_endpoint, base, size, flags); btl 359 ompi/mca/bml/bml.h mca_btl_base_module_t* btl = bml_btl->btl; btl 361 ompi/mca/bml/bml.h btl->btl_deregister_mem (btl, handle); btl 93 ompi/mca/bml/r2/bml_r2.c mca_btl_base_module_t *btl = selected_btl->btl_module; btl 94 ompi/mca/bml/r2/bml_r2.c mca_bml_r2.btl_modules[mca_bml_r2.num_btl_modules++] = btl; btl 98 ompi/mca/bml/r2/bml_r2.c btl->btl_component->btl_version.mca_component_name)) { btl 104 ompi/mca/bml/r2/bml_r2.c btl->btl_component->btl_version.mca_component_name); btl 128 ompi/mca/bml/r2/bml_r2.c return b2->btl->btl_bandwidth - b1->btl->btl_bandwidth; btl 140 ompi/mca/bml/r2/bml_r2.c mca_btl_base_module_t *btl = bml_btl->btl; btl 141 ompi/mca/bml/r2/bml_r2.c *total_bandwidth += btl->btl_bandwidth; btl 142 ompi/mca/bml/r2/bml_r2.c if (btl->btl_latency < *latency) { btl 143 ompi/mca/bml/r2/bml_r2.c *latency = btl->btl_latency; btl 169 ompi/mca/bml/r2/bml_r2.c static void mca_bml_r2_register_progress (mca_btl_base_module_t *btl, bool hp) btl 171 ompi/mca/bml/r2/bml_r2.c if (NULL != btl->btl_component->btl_progress) { btl 176 ompi/mca/bml/r2/bml_r2.c if(mca_bml_r2.btl_progress[p] == btl->btl_component->btl_progress) { btl 185 ompi/mca/bml/r2/bml_r2.c btl->btl_component->btl_progress; btl 189 ompi/mca/bml/r2/bml_r2.c opal_progress_register (btl->btl_component->btl_progress); btl 191 ompi/mca/bml/r2/bml_r2.c opal_progress_register_lp (btl->btl_component->btl_progress); btl 198 ompi/mca/bml/r2/bml_r2.c mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *btl_endpoint) btl 201 ompi/mca/bml/r2/bml_r2.c int btl_flags = btl->btl_flags; btl 207 ompi/mca/bml/r2/bml_r2.c if ((btl_flags & MCA_BTL_FLAGS_PUT) && (NULL == btl->btl_put)) { btl 211 ompi/mca/bml/r2/bml_r2.c btl->btl_component->btl_version.mca_component_name); btl 214 ompi/mca/bml/r2/bml_r2.c if ((btl_flags & MCA_BTL_FLAGS_GET) && (NULL == btl->btl_get)) { btl 217 ompi/mca/bml/r2/bml_r2.c __func__, btl->btl_component->btl_version.mca_component_name); btl 234 ompi/mca/bml/r2/bml_r2.c if (!bml_btl || bml_btl->btl->btl_exclusivity <= btl->btl_exclusivity) { btl 239 ompi/mca/bml/r2/bml_r2.c btl->btl_component->btl_version.mca_component_name, btl 244 ompi/mca/bml/r2/bml_r2.c if (NULL == bml_btl || (bml_btl->btl->btl_exclusivity <= btl->btl_exclusivity)) { btl 246 ompi/mca/bml/r2/bml_r2.c bml_btl->btl = btl; btl 259 ompi/mca/bml/r2/bml_r2.c btl->btl_component->btl_version.mca_component_name, btl 261 ompi/mca/bml/r2/bml_r2.c bml_btl->btl->btl_component->btl_version.mca_component_name, btl 262 ompi/mca/bml/r2/bml_r2.c bml_btl->btl->btl_exclusivity, btl 263 ompi/mca/bml/r2/bml_r2.c btl->btl_exclusivity); btl 274 ompi/mca/bml/r2/bml_r2.c (0 == (btl->btl_flags & MCA_BTL_FLAGS_HETEROGENEOUS_RDMA)))) { btl 277 ompi/mca/bml/r2/bml_r2.c bml_btl_rdma->btl = btl; btl 282 ompi/mca/bml/r2/bml_r2.c if (bml_endpoint->btl_pipeline_send_length < btl->btl_rdma_pipeline_send_length) { btl 283 ompi/mca/bml/r2/bml_r2.c bml_endpoint->btl_pipeline_send_length = btl->btl_rdma_pipeline_send_length; btl 286 ompi/mca/bml/r2/bml_r2.c if (bml_endpoint->btl_send_limit < btl->btl_min_rdma_pipeline_size) { btl 287 ompi/mca/bml/r2/bml_r2.c bml_endpoint->btl_send_limit = btl->btl_min_rdma_pipeline_size; btl 327 ompi/mca/bml/r2/bml_r2.c mca_btl_base_module_t *btl = bml_btl->btl; btl 330 ompi/mca/bml/r2/bml_r2.c if(btl->btl_bandwidth > 0) { btl 331 ompi/mca/bml/r2/bml_r2.c bml_btl->btl_weight = (float)(btl->btl_bandwidth / total_bandwidth); btl 339 ompi/mca/bml/r2/bml_r2.c if(btl->btl_latency == latency) { btl 346 ompi/mca/bml/r2/bml_r2.c if (bml_endpoint->btl_max_send_size > btl->btl_max_send_size) btl 347 ompi/mca/bml/r2/bml_r2.c bml_endpoint->btl_max_send_size = btl->btl_max_send_size; btl 362 ompi/mca/bml/r2/bml_r2.c if (bml_btl->btl->btl_bandwidth > 0.0) { btl 363 ompi/mca/bml/r2/bml_r2.c bml_btl->btl_weight = (float)(bml_btl->btl->btl_bandwidth / total_bandwidth); btl 398 ompi/mca/bml/r2/bml_r2.c mca_btl_base_module_t *btl = mca_bml_r2.btl_modules[p_index]; btl 406 ompi/mca/bml/r2/bml_r2.c rc = btl->btl_add_procs (btl, 1, (opal_proc_t **) &proc, &btl_endpoint, NULL); btl 413 ompi/mca/bml/r2/bml_r2.c rc = mca_bml_r2_endpoint_add_btl (proc, bml_endpoint, btl, btl_endpoint); btl 415 ompi/mca/bml/r2/bml_r2.c btl->btl_del_procs (btl, 1, (opal_proc_t **) &proc, &btl_endpoint); btl 417 ompi/mca/bml/r2/bml_r2.c mca_bml_r2_register_progress (btl, true); btl 510 ompi/mca/bml/r2/bml_r2.c mca_btl_base_module_t *btl = mca_bml_r2.btl_modules[p_index]; btl 521 ompi/mca/bml/r2/bml_r2.c rc = btl->btl_add_procs(btl, n_new_procs, (opal_proc_t**)new_procs, btl_endpoints, reachable); btl 548 ompi/mca/bml/r2/bml_r2.c rc = mca_bml_r2_endpoint_add_btl (proc, bml_endpoint, btl, btl_endpoints[p]); btl 550 ompi/mca/bml/r2/bml_r2.c btl->btl_del_procs(btl, 1, (opal_proc_t**)&proc, &btl_endpoints[p]); btl 558 ompi/mca/bml/r2/bml_r2.c mca_bml_r2_register_progress (btl, !!(btl_inuse)); btl 622 ompi/mca/bml/r2/bml_r2.c mca_btl_base_module_t *btl = bml_btl->btl; btl 624 ompi/mca/bml/r2/bml_r2.c int rc = btl->btl_del_procs (btl, 1, (opal_proc_t **) &proc, &bml_btl->btl_endpoint); btl 639 ompi/mca/bml/r2/bml_r2.c mca_btl_base_module_t *btl = rdma_btl->btl; btl 651 ompi/mca/bml/r2/bml_r2.c int rc = btl->btl_del_procs (btl, 1, (opal_proc_t **) &proc, &rdma_btl->btl_endpoint); btl 670 ompi/mca/bml/r2/bml_r2.c static inline int bml_r2_remove_btl_progress(mca_btl_base_module_t* btl) btl 674 ompi/mca/bml/r2/bml_r2.c if(NULL == btl->btl_component->btl_progress) { btl 678 ompi/mca/bml/r2/bml_r2.c if(btl->btl_component->btl_progress != mca_bml_r2.btl_progress[p]) btl 680 ompi/mca/bml/r2/bml_r2.c opal_progress_unregister( btl->btl_component->btl_progress ); btl 690 ompi/mca/bml/r2/bml_r2.c static int mca_bml_r2_del_proc_btl(ompi_proc_t* proc, mca_btl_base_module_t* btl) btl 702 ompi/mca/bml/r2/bml_r2.c mca_bml_base_btl_array_remove(&ep->btl_eager, btl); btl 705 ompi/mca/bml/r2/bml_r2.c if(mca_bml_base_btl_array_remove(&ep->btl_send, btl)) { btl 713 ompi/mca/bml/r2/bml_r2.c ep_btl = bml_btl->btl; btl 724 ompi/mca/bml/r2/bml_r2.c ep_btl = bml_btl->btl; btl 735 ompi/mca/bml/r2/bml_r2.c if(mca_bml_base_btl_array_remove(&ep->btl_rdma, btl)) { btl 743 ompi/mca/bml/r2/bml_r2.c ep_btl = bml_btl->btl; btl 758 ompi/mca/bml/r2/bml_r2.c ep_btl = bml_btl->btl; btl 791 ompi/mca/bml/r2/bml_r2.c mca_btl_base_module_t* btl = sm->btl_module; btl 794 ompi/mca/bml/r2/bml_r2.c bml_r2_remove_btl_progress(btl); btl 833 ompi/mca/bml/r2/bml_r2.c static int mca_bml_r2_del_btl(mca_btl_base_module_t* btl) btl 851 ompi/mca/bml/r2/bml_r2.c bml_r2_remove_btl_progress(btl); btl 856 ompi/mca/bml/r2/bml_r2.c mca_bml_r2_del_proc_btl(proc, btl); btl 864 ompi/mca/bml/r2/bml_r2.c if(sm->btl_module == btl) { btl 878 ompi/mca/bml/r2/bml_r2.c if(mca_bml_r2.btl_modules[i] != btl) { btl 887 ompi/mca/bml/r2/bml_r2.c btl->btl_finalize(btl); btl 897 ompi/mca/bml/r2/bml_r2.c static int mca_bml_r2_add_btl(mca_btl_base_module_t* btl) btl 917 ompi/mca/bml/r2/bml_r2.c mca_btl_base_module_t *btl; btl 920 ompi/mca/bml/r2/bml_r2.c btl = mca_bml_r2.btl_modules[i]; btl 921 ompi/mca/bml/r2/bml_r2.c if( NULL == btl->btl_register ) btl 923 ompi/mca/bml/r2/bml_r2.c rc = btl->btl_register(btl, tag, cbfunc, data); btl 943 ompi/mca/bml/r2/bml_r2.c mca_btl_base_module_t *btl; btl 947 ompi/mca/bml/r2/bml_r2.c btl = mca_bml_r2.btl_modules[i]; btl 950 ompi/mca/bml/r2/bml_r2.c ver = btl->btl_component->btl_version.mca_type_major_version << 16 | btl 951 ompi/mca/bml/r2/bml_r2.c btl->btl_component->btl_version.mca_type_minor_version << 8 | btl 952 ompi/mca/bml/r2/bml_r2.c btl->btl_component->btl_version.mca_type_release_version; btl 955 ompi/mca/bml/r2/bml_r2.c NULL != btl->btl_register_error) { btl 956 ompi/mca/bml/r2/bml_r2.c rc = btl->btl_register_error(btl, cbfunc); btl 113 ompi/mca/crcp/base/base.h ompi_crcp_base_none_btl_add_procs( struct mca_btl_base_module_t* btl, btl 121 ompi/mca/crcp/base/base.h ompi_crcp_base_none_btl_del_procs( struct mca_btl_base_module_t* btl, btl 128 ompi/mca/crcp/base/base.h ompi_crcp_base_none_btl_register( struct mca_btl_base_module_t* btl, btl 135 ompi/mca/crcp/base/base.h ompi_crcp_base_none_btl_finalize( struct mca_btl_base_module_t* btl, btl 139 ompi/mca/crcp/base/base.h ompi_crcp_base_none_btl_alloc( struct mca_btl_base_module_t* btl, btl 144 ompi/mca/crcp/base/base.h ompi_crcp_base_none_btl_free( struct mca_btl_base_module_t* btl, btl 149 ompi/mca/crcp/base/base.h ompi_crcp_base_none_btl_prepare_src( struct mca_btl_base_module_t* btl, btl 158 ompi/mca/crcp/base/base.h ompi_crcp_base_none_btl_prepare_dst( struct mca_btl_base_module_t* btl, btl 167 ompi/mca/crcp/base/base.h ompi_crcp_base_none_btl_send( struct mca_btl_base_module_t* btl, btl 174 ompi/mca/crcp/base/base.h ompi_crcp_base_none_btl_put( struct mca_btl_base_module_t* btl, btl 180 ompi/mca/crcp/base/base.h ompi_crcp_base_none_btl_get( struct mca_btl_base_module_t* btl, btl 186 ompi/mca/crcp/base/base.h ompi_crcp_base_none_btl_dump( struct mca_btl_base_module_t* btl, btl 277 ompi/mca/crcp/base/crcp_base_fns.c ompi_crcp_base_none_btl_add_procs( struct mca_btl_base_module_t* btl, btl 289 ompi/mca/crcp/base/crcp_base_fns.c ompi_crcp_base_none_btl_del_procs( struct mca_btl_base_module_t* btl, btl 300 ompi/mca/crcp/base/crcp_base_fns.c ompi_crcp_base_none_btl_register( struct mca_btl_base_module_t* btl, btl 311 ompi/mca/crcp/base/crcp_base_fns.c ompi_crcp_base_none_btl_finalize( struct mca_btl_base_module_t* btl, btl 319 ompi/mca/crcp/base/crcp_base_fns.c ompi_crcp_base_none_btl_alloc( struct mca_btl_base_module_t* btl, btl 328 ompi/mca/crcp/base/crcp_base_fns.c ompi_crcp_base_none_btl_free( struct mca_btl_base_module_t* btl, btl 337 ompi/mca/crcp/base/crcp_base_fns.c ompi_crcp_base_none_btl_prepare_src( struct mca_btl_base_module_t* btl, btl 350 ompi/mca/crcp/base/crcp_base_fns.c ompi_crcp_base_none_btl_prepare_dst( struct mca_btl_base_module_t* btl, btl 363 ompi/mca/crcp/base/crcp_base_fns.c ompi_crcp_base_none_btl_send( struct mca_btl_base_module_t* btl, btl 374 ompi/mca/crcp/base/crcp_base_fns.c ompi_crcp_base_none_btl_put( struct mca_btl_base_module_t* btl, btl 384 ompi/mca/crcp/base/crcp_base_fns.c ompi_crcp_base_none_btl_get( struct mca_btl_base_module_t* btl, btl 395 ompi/mca/crcp/base/crcp_base_fns.c ompi_crcp_base_none_btl_dump( struct mca_btl_base_module_t* btl, btl 47 ompi/mca/crcp/bkmrk/crcp_bkmrk_btl.c ompi_crcp_base_coord_btl_add_procs( struct mca_btl_base_module_t* btl, btl 59 ompi/mca/crcp/bkmrk/crcp_bkmrk_btl.c ompi_crcp_base_coord_btl_del_procs( struct mca_btl_base_module_t* btl, btl 70 ompi/mca/crcp/bkmrk/crcp_bkmrk_btl.c ompi_crcp_base_coord_btl_register( struct mca_btl_base_module_t* btl, btl 81 ompi/mca/crcp/bkmrk/crcp_bkmrk_btl.c ompi_crcp_base_coord_btl_finalize( struct mca_btl_base_module_t* btl, btl 89 ompi/mca/crcp/bkmrk/crcp_bkmrk_btl.c ompi_crcp_base_coord_btl_alloc( struct mca_btl_base_module_t* btl, btl 98 ompi/mca/crcp/bkmrk/crcp_bkmrk_btl.c ompi_crcp_base_coord_btl_free( struct mca_btl_base_module_t* btl, btl 107 ompi/mca/crcp/bkmrk/crcp_bkmrk_btl.c ompi_crcp_base_coord_btl_prepare_src( struct mca_btl_base_module_t* btl, btl 120 ompi/mca/crcp/bkmrk/crcp_bkmrk_btl.c ompi_crcp_base_coord_btl_prepare_dst( struct mca_btl_base_module_t* btl, btl 133 ompi/mca/crcp/bkmrk/crcp_bkmrk_btl.c ompi_crcp_base_coord_btl_send( struct mca_btl_base_module_t* btl, btl 144 ompi/mca/crcp/bkmrk/crcp_bkmrk_btl.c ompi_crcp_base_coord_btl_put( struct mca_btl_base_module_t* btl, btl 154 ompi/mca/crcp/bkmrk/crcp_bkmrk_btl.c ompi_crcp_base_coord_btl_get( struct mca_btl_base_module_t* btl, btl 165 ompi/mca/crcp/bkmrk/crcp_bkmrk_btl.c ompi_crcp_base_coord_btl_dump( struct mca_btl_base_module_t* btl, btl 40 ompi/mca/crcp/bkmrk/crcp_bkmrk_btl.h ( struct mca_btl_base_module_t* btl, btl 48 ompi/mca/crcp/bkmrk/crcp_bkmrk_btl.h ( struct mca_btl_base_module_t* btl, btl 55 ompi/mca/crcp/bkmrk/crcp_bkmrk_btl.h ( struct mca_btl_base_module_t* btl, btl 62 ompi/mca/crcp/bkmrk/crcp_bkmrk_btl.h ( struct mca_btl_base_module_t* btl, btl 66 ompi/mca/crcp/bkmrk/crcp_bkmrk_btl.h ( struct mca_btl_base_module_t* btl, btl 71 ompi/mca/crcp/bkmrk/crcp_bkmrk_btl.h ( struct mca_btl_base_module_t* btl, btl 76 ompi/mca/crcp/bkmrk/crcp_bkmrk_btl.h ( struct mca_btl_base_module_t* btl, btl 85 ompi/mca/crcp/bkmrk/crcp_bkmrk_btl.h ( struct mca_btl_base_module_t* btl, btl 94 ompi/mca/crcp/bkmrk/crcp_bkmrk_btl.h ( struct mca_btl_base_module_t* btl, btl 101 ompi/mca/crcp/bkmrk/crcp_bkmrk_btl.h ( struct mca_btl_base_module_t* btl, btl 107 ompi/mca/crcp/bkmrk/crcp_bkmrk_btl.h ( struct mca_btl_base_module_t* btl, btl 113 ompi/mca/crcp/bkmrk/crcp_bkmrk_btl.h ( struct mca_btl_base_module_t* btl, btl 200 ompi/mca/crcp/crcp.h ( struct mca_btl_base_module_t* btl, btl 208 ompi/mca/crcp/crcp.h ( struct mca_btl_base_module_t* btl, btl 215 ompi/mca/crcp/crcp.h ( struct mca_btl_base_module_t* btl, btl 222 ompi/mca/crcp/crcp.h ( struct mca_btl_base_module_t* btl, btl 226 ompi/mca/crcp/crcp.h ( struct mca_btl_base_module_t* btl, btl 231 ompi/mca/crcp/crcp.h ( struct mca_btl_base_module_t* btl, btl 236 ompi/mca/crcp/crcp.h ( struct mca_btl_base_module_t* btl, btl 245 ompi/mca/crcp/crcp.h ( struct mca_btl_base_module_t* btl, btl 252 ompi/mca/crcp/crcp.h ( struct mca_btl_base_module_t* btl, btl 258 ompi/mca/crcp/crcp.h ( struct mca_btl_base_module_t* btl, btl 264 ompi/mca/crcp/crcp.h ( struct mca_btl_base_module_t* btl, btl 677 ompi/mca/osc/rdma/osc_rdma_accumulate.c static void ompi_osc_rdma_cas_put_complete (struct mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint, btl 82 ompi/mca/osc/rdma/osc_rdma_active_target.c void ompi_osc_rdma_atomic_complete (mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint, btl 49 ompi/mca/osc/rdma/osc_rdma_comm.c static void ompi_osc_get_data_complete (struct mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint, btl 381 ompi/mca/osc/rdma/osc_rdma_comm.c static void ompi_osc_rdma_put_complete (struct mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint, btl 410 ompi/mca/osc/rdma/osc_rdma_comm.c static void ompi_osc_rdma_put_complete_flush (struct mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint, btl 531 ompi/mca/osc/rdma/osc_rdma_comm.c static void ompi_osc_rdma_get_complete (struct mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint, btl 78 ompi/mca/osc/rdma/osc_rdma_component.c static int ompi_osc_rdma_query_btls (ompi_communicator_t *comm, struct mca_btl_base_module_t **btl); btl 784 ompi/mca/osc/rdma/osc_rdma_component.c static int ompi_osc_rdma_query_btls (ompi_communicator_t *comm, struct mca_btl_base_module_t **btl) btl 817 ompi/mca/osc/rdma/osc_rdma_component.c if (btl) { btl 818 ompi/mca/osc/rdma/osc_rdma_component.c *btl = selected_btl; btl 870 ompi/mca/osc/rdma/osc_rdma_component.c if ((endpoint->btl_rdma.bml_btls[i_btl].btl->btl_flags & (MCA_BTL_FLAGS_RDMA | MCA_BTL_FLAGS_ATOMIC_FOPS)) == btl 871 ompi/mca/osc/rdma/osc_rdma_component.c (MCA_BTL_FLAGS_RDMA | MCA_BTL_FLAGS_ATOMIC_FOPS) && (endpoint->btl_rdma.bml_btls[i_btl].btl->btl_atomic_flags & btl 874 ompi/mca/osc/rdma/osc_rdma_component.c if (endpoint->btl_rdma.bml_btls[i_btl].btl == possible_btls[j]) { btl 878 ompi/mca/osc/rdma/osc_rdma_component.c possible_btls[j] = endpoint->btl_rdma.bml_btls[i_btl].btl; btl 916 ompi/mca/osc/rdma/osc_rdma_component.c if (btl) { btl 917 ompi/mca/osc/rdma/osc_rdma_component.c *btl = selected_btl; btl 32 ompi/mca/osc/rdma/osc_rdma_lock.h void ompi_osc_rdma_atomic_complete (mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint, btl 48 ompi/mca/osc/rdma/osc_rdma_peer.c if (bml_endpoint->btl_rdma.bml_btls[btl_index].btl == module->selected_btl) { btl 87 ompi/mca/pml/ob1/pml_ob1.c extern void mca_pml_ob1_cuda_add_ipc_support(struct mca_btl_base_module_t* btl, btl 92 ompi/mca/pml/ob1/pml_ob1.c void mca_pml_ob1_error_handler( struct mca_btl_base_module_t* btl, btl 652 ompi/mca/pml/ob1/pml_ob1.c bml_btl->btl->btl_dump(bml_btl->btl, bml_btl->btl_endpoint, verbose); btl 658 ompi/mca/pml/ob1/pml_ob1.c static void mca_pml_ob1_fin_completion( mca_btl_base_module_t* btl, btl 729 ompi/mca/pml/ob1/pml_ob1.c pckt->bml_btl->btl == bml_btl->btl) { btl 735 ompi/mca/pml/ob1/pml_ob1.c &endpoint->btl_eager, bml_btl->btl); btl 810 ompi/mca/pml/ob1/pml_ob1.c struct mca_btl_base_module_t* btl, int32_t flags, btl 814 ompi/mca/pml/ob1/pml_ob1.c mca_pml_ob1_cuda_add_ipc_support(btl, flags, (struct ompi_proc_t*)errproc, btlinfo); btl 385 ompi/mca/pml/ob1/pml_ob1.h length = (length_left > bml_btl->btl->btl_eager_limit)? btl 302 ompi/mca/pml/ob1/pml_ob1_component.c mca_btl_base_module_t *btl = selected_btl->btl_module; btl 304 ompi/mca/pml/ob1/pml_ob1_component.c if (btl->btl_flags & MCA_BTL_FLAGS_BTL_PROGRESS_THREAD_ENABLED) { btl 308 ompi/mca/pml/ob1/pml_ob1_component.c if (btl->btl_flags & MCA_BTL_FLAGS_SINGLE_ADD_PROCS) { btl 48 ompi/mca/pml/ob1/pml_ob1_cuda.c mca_btl_base_module_t* btl); btl 50 ompi/mca/pml/ob1/pml_ob1_cuda.c void mca_pml_ob1_cuda_add_ipc_support(struct mca_btl_base_module_t* btl, int32_t flags, btl 63 ompi/mca/pml/ob1/pml_ob1_cuda.c (sendreq->req_send.req_bytes_packed > (bml_btl->btl->btl_cuda_rdma_limit - sizeof(mca_pml_ob1_hdr_t)))) { btl 127 ompi/mca/pml/ob1/pml_ob1_cuda.c if( NULL != bml_btl->btl->btl_register_mem ) { btl 129 ompi/mca/pml/ob1/pml_ob1_cuda.c handle = bml_btl->btl->btl_register_mem (bml_btl->btl, bml_btl->btl_endpoint, btl 157 ompi/mca/pml/ob1/pml_ob1_cuda.c mca_btl_base_module_t* btl) btl 161 ompi/mca/pml/ob1/pml_ob1_cuda.c mca_bml_base_btl_t *bml_btl = mca_bml_base_btl_array_find(&bml_endpoint->btl_send, btl); btl 165 ompi/mca/pml/ob1/pml_ob1_cuda.c bml_btl = mca_bml_base_btl_array_find(&bml_endpoint->btl_rdma, btl); btl 189 ompi/mca/pml/ob1/pml_ob1_cuda.c void mca_pml_ob1_cuda_add_ipc_support(struct mca_btl_base_module_t* btl, int32_t flags, btl 205 ompi/mca/pml/ob1/pml_ob1_cuda.c if( ep->btl_send.bml_btls[i].btl == btl ) { btl 210 ompi/mca/pml/ob1/pml_ob1_cuda.c btl->btl_component->btl_version.mca_component_name, btl 244 ompi/mca/pml/ob1/pml_ob1_irecv.c mca_pml_ob1_recv_request_progress_match(recvreq, frag->btl, frag->segments, btl 248 ompi/mca/pml/ob1/pml_ob1_irecv.c mca_pml_ob1_recv_request_progress_rndv(recvreq, frag->btl, frag->segments, btl 252 ompi/mca/pml/ob1/pml_ob1_irecv.c mca_pml_ob1_recv_request_progress_rget(recvreq, frag->btl, frag->segments, btl 336 ompi/mca/pml/ob1/pml_ob1_irecv.c mca_pml_ob1_recv_request_progress_match(recvreq, frag->btl, frag->segments, btl 340 ompi/mca/pml/ob1/pml_ob1_irecv.c mca_pml_ob1_recv_request_progress_rndv(recvreq, frag->btl, frag->segments, btl 344 ompi/mca/pml/ob1/pml_ob1_irecv.c mca_pml_ob1_recv_request_progress_rget(recvreq, frag->btl, frag->segments, btl 91 ompi/mca/pml/ob1/pml_ob1_isend.c if( NULL == bml_btl->btl->btl_sendi) btl 61 ompi/mca/pml/ob1/pml_ob1_rdma.c mca_btl_base_module_t *btl = bml_btl->btl; btl 79 ompi/mca/pml/ob1/pml_ob1_rdma.c if (btl->btl_register_mem) { btl 83 ompi/mca/pml/ob1/pml_ob1_rdma.c if (!opal_leave_pinned && (btl->btl_flags & MCA_BTL_FLAGS_PUT) && btl 84 ompi/mca/pml/ob1/pml_ob1_rdma.c size > btl->btl_min_rdma_pipeline_size) { btl 89 ompi/mca/pml/ob1/pml_ob1_rdma.c reg_handle = btl->btl_register_mem (btl, bml_btl->btl_endpoint, base, btl 78 ompi/mca/pml/ob1/pml_ob1_recvfrag.c append_frag_to_list(opal_list_t *queue, mca_btl_base_module_t *btl, btl 84 ompi/mca/pml/ob1/pml_ob1_recvfrag.c MCA_PML_OB1_RECV_FRAG_INIT(frag, hdr, segments, num_segments, btl); btl 92 ompi/mca/pml/ob1/pml_ob1_recvfrag.c append_frag_to_umq(custom_match_umq *queue, mca_btl_base_module_t *btl, btl 98 ompi/mca/pml/ob1/pml_ob1_recvfrag.c MCA_PML_OB1_RECV_FRAG_INIT(frag, hdr, segments, num_segments, btl); btl 296 ompi/mca/pml/ob1/pml_ob1_recvfrag.c static int mca_pml_ob1_recv_frag_match( mca_btl_base_module_t *btl, btl 316 ompi/mca/pml/ob1/pml_ob1_recvfrag.c mca_pml_ob1_recv_frag_match_proc( mca_btl_base_module_t *btl, btl 326 ompi/mca/pml/ob1/pml_ob1_recvfrag.c match_one(mca_btl_base_module_t *btl, btl 343 ompi/mca/pml/ob1/pml_ob1_recvfrag.c void mca_pml_ob1_recv_frag_callback_match(mca_btl_base_module_t* btl, btl 375 ompi/mca/pml/ob1/pml_ob1_recvfrag.c btl, hdr, segments, num_segments, NULL ); btl 409 ompi/mca/pml/ob1/pml_ob1_recvfrag.c MCA_PML_OB1_RECV_FRAG_INIT(frag, hdr, segments, num_segments, btl); btl 427 ompi/mca/pml/ob1/pml_ob1_recvfrag.c match = match_one(btl, hdr, segments, num_segments, comm_ptr, proc, NULL); btl 509 ompi/mca/pml/ob1/pml_ob1_recvfrag.c mca_pml_ob1_recv_frag_match_proc(frag->btl, comm_ptr, proc, btl 522 ompi/mca/pml/ob1/pml_ob1_recvfrag.c void mca_pml_ob1_recv_frag_callback_rndv(mca_btl_base_module_t* btl, btl 534 ompi/mca/pml/ob1/pml_ob1_recvfrag.c mca_pml_ob1_recv_frag_match(btl, &hdr->hdr_match, segments, btl 539 ompi/mca/pml/ob1/pml_ob1_recvfrag.c void mca_pml_ob1_recv_frag_callback_rget(mca_btl_base_module_t* btl, btl 551 ompi/mca/pml/ob1/pml_ob1_recvfrag.c mca_pml_ob1_recv_frag_match(btl, &hdr->hdr_match, segments, btl 558 ompi/mca/pml/ob1/pml_ob1_recvfrag.c void mca_pml_ob1_recv_frag_callback_ack(mca_btl_base_module_t* btl, btl 610 ompi/mca/pml/ob1/pml_ob1_recvfrag.c (btl->btl_flags & MCA_BTL_FLAGS_CUDA_COPY_ASYNC_SEND)) { btl 625 ompi/mca/pml/ob1/pml_ob1_recvfrag.c void mca_pml_ob1_recv_frag_callback_frag(mca_btl_base_module_t* btl, btl 644 ompi/mca/pml/ob1/pml_ob1_recvfrag.c assert(btl->btl_flags & MCA_BTL_FLAGS_CUDA_COPY_ASYNC_RECV); btl 647 ompi/mca/pml/ob1/pml_ob1_recvfrag.c mca_pml_ob1_recv_request_frag_copy_start(recvreq,btl,segments,des->des_segment_count,des); btl 656 ompi/mca/pml/ob1/pml_ob1_recvfrag.c mca_pml_ob1_recv_request_progress_frag(recvreq,btl,segments,des->des_segment_count); btl 662 ompi/mca/pml/ob1/pml_ob1_recvfrag.c void mca_pml_ob1_recv_frag_callback_put(mca_btl_base_module_t* btl, btl 676 ompi/mca/pml/ob1/pml_ob1_recvfrag.c mca_pml_ob1_send_request_put(sendreq,btl,&hdr->hdr_rdma); btl 682 ompi/mca/pml/ob1/pml_ob1_recvfrag.c void mca_pml_ob1_recv_frag_callback_fin(mca_btl_base_module_t* btl, btl 799 ompi/mca/pml/ob1/pml_ob1_recvfrag.c match_one(mca_btl_base_module_t *btl, btl 830 ompi/mca/pml/ob1/pml_ob1_recvfrag.c mca_pml_ob1_recv_request_matched_probe(match, btl, segments, btl 841 ompi/mca/pml/ob1/pml_ob1_recvfrag.c MCA_PML_OB1_RECV_FRAG_INIT(tmp, hdr, segments, num_segments, btl); btl 847 ompi/mca/pml/ob1/pml_ob1_recvfrag.c mca_pml_ob1_recv_request_matched_probe(match, btl, segments, btl 863 ompi/mca/pml/ob1/pml_ob1_recvfrag.c append_frag_to_umq(comm->umq, btl, hdr, segments, btl 866 ompi/mca/pml/ob1/pml_ob1_recvfrag.c append_frag_to_list(&proc->unexpected_frags, btl, hdr, segments, btl 909 ompi/mca/pml/ob1/pml_ob1_recvfrag.c static int mca_pml_ob1_recv_frag_match( mca_btl_base_module_t *btl, btl 933 ompi/mca/pml/ob1/pml_ob1_recvfrag.c btl, hdr, segments, num_segments, NULL ); btl 967 ompi/mca/pml/ob1/pml_ob1_recvfrag.c MCA_PML_OB1_RECV_FRAG_INIT(frag, hdr, segments, num_segments, btl); btl 980 ompi/mca/pml/ob1/pml_ob1_recvfrag.c return mca_pml_ob1_recv_frag_match_proc(btl, comm_ptr, proc, hdr, btl 993 ompi/mca/pml/ob1/pml_ob1_recvfrag.c mca_pml_ob1_recv_frag_match_proc( mca_btl_base_module_t *btl, btl 1025 ompi/mca/pml/ob1/pml_ob1_recvfrag.c match = match_one(btl, hdr, segments, num_segments, comm_ptr, proc, frag); btl 1040 ompi/mca/pml/ob1/pml_ob1_recvfrag.c mca_pml_ob1_recv_request_progress_match(match, btl, segments, num_segments); btl 1043 ompi/mca/pml/ob1/pml_ob1_recvfrag.c mca_pml_ob1_recv_request_progress_rndv(match, btl, segments, num_segments); btl 1046 ompi/mca/pml/ob1/pml_ob1_recvfrag.c mca_pml_ob1_recv_request_progress_rget(match, btl, segments, num_segments); btl 1065 ompi/mca/pml/ob1/pml_ob1_recvfrag.c btl = frag->btl; btl 46 ompi/mca/pml/ob1/pml_ob1_recvfrag.h mca_btl_base_module_t* btl; btl 63 ompi/mca/pml/ob1/pml_ob1_recvfrag.h #define MCA_PML_OB1_RECV_FRAG_INIT(frag, hdr, segs, cnt, btl ) \ btl 70 ompi/mca/pml/ob1/pml_ob1_recvfrag.h frag->btl = btl; \ btl 116 ompi/mca/pml/ob1/pml_ob1_recvfrag.h extern void mca_pml_ob1_recv_frag_callback_match( mca_btl_base_module_t *btl, btl 125 ompi/mca/pml/ob1/pml_ob1_recvfrag.h extern void mca_pml_ob1_recv_frag_callback_rndv( mca_btl_base_module_t *btl, btl 133 ompi/mca/pml/ob1/pml_ob1_recvfrag.h extern void mca_pml_ob1_recv_frag_callback_rget( mca_btl_base_module_t *btl, btl 142 ompi/mca/pml/ob1/pml_ob1_recvfrag.h extern void mca_pml_ob1_recv_frag_callback_ack( mca_btl_base_module_t *btl, btl 150 ompi/mca/pml/ob1/pml_ob1_recvfrag.h extern void mca_pml_ob1_recv_frag_callback_frag( mca_btl_base_module_t *btl, btl 158 ompi/mca/pml/ob1/pml_ob1_recvfrag.h extern void mca_pml_ob1_recv_frag_callback_put( mca_btl_base_module_t *btl, btl 166 ompi/mca/pml/ob1/pml_ob1_recvfrag.h extern void mca_pml_ob1_recv_frag_callback_fin( mca_btl_base_module_t *btl, btl 51 ompi/mca/pml/ob1/pml_ob1_recvreq.c mca_btl_base_module_t* btl); btl 181 ompi/mca/pml/ob1/pml_ob1_recvreq.c static void mca_pml_ob1_recv_ctl_completion( mca_btl_base_module_t* btl, btl 375 ompi/mca/pml/ob1/pml_ob1_recvreq.c static void mca_pml_ob1_rget_completion (mca_btl_base_module_t* btl, struct mca_btl_base_endpoint_t* ep, btl 423 ompi/mca/pml/ob1/pml_ob1_recvreq.c reg_size = bml_btl->btl->btl_registration_handle_size; btl 479 ompi/mca/pml/ob1/pml_ob1_recvreq.c if (bml_btl->btl->btl_register_mem && !frag->local_handle && !recvreq->local_handle) { btl 519 ompi/mca/pml/ob1/pml_ob1_recvreq.c mca_btl_base_module_t* btl, btl 578 ompi/mca/pml/ob1/pml_ob1_recvreq.c mca_btl_base_module_t* btl, btl 623 ompi/mca/pml/ob1/pml_ob1_recvreq.c void mca_pml_ob1_recv_request_frag_copy_finished( mca_btl_base_module_t* btl, btl 654 ompi/mca/pml/ob1/pml_ob1_recvreq.c mca_btl_base_module_t* btl, btl 678 ompi/mca/pml/ob1/pml_ob1_recvreq.c if (mca_pml_ob1_cuda_need_buffers(recvreq, btl)) btl 688 ompi/mca/pml/ob1/pml_ob1_recvreq.c rdma_bml = mca_bml_base_btl_array_find(&bml_endpoint->btl_rdma, btl); btl 694 ompi/mca/pml/ob1/pml_ob1_recvreq.c bml_btl = mca_bml_base_btl_array_find(&bml_endpoint->btl_send, btl); btl 719 ompi/mca/pml/ob1/pml_ob1_recvreq.c if (rdma_bml->btl->btl_register_mem) { btl 763 ompi/mca/pml/ob1/pml_ob1_recvreq.c memcpy (frag->remote_handle, hdr + 1, btl->btl_registration_handle_size); btl 783 ompi/mca/pml/ob1/pml_ob1_recvreq.c if (bytes_remaining > rdma_bml->btl->btl_get_limit) { btl 784 ompi/mca/pml/ob1/pml_ob1_recvreq.c frag->rdma_length = rdma_bml->btl->btl_get_limit; btl 808 ompi/mca/pml/ob1/pml_ob1_recvreq.c mca_btl_base_module_t* btl, btl 865 ompi/mca/pml/ob1/pml_ob1_recvreq.c (btl->btl_flags & MCA_BTL_FLAGS_CUDA_COPY_ASYNC_RECV)) { btl 878 ompi/mca/pml/ob1/pml_ob1_recvreq.c mca_btl_base_module_t* btl, btl 934 ompi/mca/pml/ob1/pml_ob1_recvreq.c mca_btl_base_module_t* btl, btl 992 ompi/mca/pml/ob1/pml_ob1_recvreq.c mca_btl_base_module_t *btl; btl 1020 ompi/mca/pml/ob1/pml_ob1_recvreq.c btl = bml_btl->btl; btl 1025 ompi/mca/pml/ob1/pml_ob1_recvreq.c if ((btl->btl_rdma_pipeline_frag_size != 0) && (size > btl->btl_rdma_pipeline_frag_size)) { btl 1026 ompi/mca/pml/ob1/pml_ob1_recvreq.c size = btl->btl_rdma_pipeline_frag_size; btl 1042 ompi/mca/pml/ob1/pml_ob1_recvreq.c if (btl->btl_register_mem) { btl 1340 ompi/mca/pml/ob1/pml_ob1_recvreq.c mca_pml_ob1_recv_request_progress_match(req, frag->btl, frag->segments, btl 1344 ompi/mca/pml/ob1/pml_ob1_recvreq.c mca_pml_ob1_recv_request_progress_rndv(req, frag->btl, frag->segments, btl 1348 ompi/mca/pml/ob1/pml_ob1_recvreq.c mca_pml_ob1_recv_request_progress_rget(req, frag->btl, frag->segments, btl 1375 ompi/mca/pml/ob1/pml_ob1_recvreq.c mca_pml_ob1_recv_request_matched_probe(req, frag->btl, btl 1380 ompi/mca/pml/ob1/pml_ob1_recvreq.c mca_pml_ob1_recv_request_matched_probe(req, frag->btl, btl 316 ompi/mca/pml/ob1/pml_ob1_recvreq.h struct mca_btl_base_module_t* btl, btl 326 ompi/mca/pml/ob1/pml_ob1_recvreq.h struct mca_btl_base_module_t* btl, btl 333 ompi/mca/pml/ob1/pml_ob1_recvreq.h struct mca_btl_base_module_t* btl, btl 338 ompi/mca/pml/ob1/pml_ob1_recvreq.h void mca_pml_ob1_recv_request_frag_copy_finished(struct mca_btl_base_module_t* btl, btl 349 ompi/mca/pml/ob1/pml_ob1_recvreq.h struct mca_btl_base_module_t* btl, btl 359 ompi/mca/pml/ob1/pml_ob1_recvreq.h struct mca_btl_base_module_t* btl, btl 369 ompi/mca/pml/ob1/pml_ob1_recvreq.h struct mca_btl_base_module_t* btl, btl 70 ompi/mca/pml/ob1/pml_ob1_sendreq.c &sendreq->req_endpoint->btl_eager, bml_btl->btl); btl 179 ompi/mca/pml/ob1/pml_ob1_sendreq.c mca_pml_ob1_match_completion_free( struct mca_btl_base_module_t* btl, btl 224 ompi/mca/pml/ob1/pml_ob1_sendreq.c mca_pml_ob1_rndv_completion( mca_btl_base_module_t* btl, btl 288 ompi/mca/pml/ob1/pml_ob1_sendreq.c mca_pml_ob1_send_ctl_completion( mca_btl_base_module_t* btl, btl 305 ompi/mca/pml/ob1/pml_ob1_sendreq.c mca_pml_ob1_frag_completion( mca_btl_base_module_t* btl, btl 346 ompi/mca/pml/ob1/pml_ob1_sendreq.c mca_pml_ob1_copy_frag_completion( mca_btl_base_module_t* btl, btl 495 ompi/mca/pml/ob1/pml_ob1_sendreq.c if(NULL != bml_btl->btl->btl_sendi) { btl 712 ompi/mca/pml/ob1/pml_ob1_sendreq.c reg_size = bml_btl->btl->btl_registration_handle_size; btl 983 ompi/mca/pml/ob1/pml_ob1_sendreq.c if(bml_btl->btl->btl_max_send_size != 0) { btl 986 ompi/mca/pml/ob1/pml_ob1_sendreq.c if ((sendreq->req_send.req_base.req_convertor.flags & CONVERTOR_CUDA) && (bml_btl->btl->btl_cuda_max_send_size != 0)) { btl 987 ompi/mca/pml/ob1/pml_ob1_sendreq.c max_send_size = bml_btl->btl->btl_cuda_max_send_size - sizeof(mca_pml_ob1_frag_hdr_t); btl 989 ompi/mca/pml/ob1/pml_ob1_sendreq.c max_send_size = bml_btl->btl->btl_max_send_size - sizeof(mca_pml_ob1_frag_hdr_t); btl 992 ompi/mca/pml/ob1/pml_ob1_sendreq.c size_t max_send_size = bml_btl->btl->btl_max_send_size - btl 1134 ompi/mca/pml/ob1/pml_ob1_sendreq.c static void mca_pml_ob1_put_completion (mca_btl_base_module_t* btl, struct mca_btl_base_endpoint_t* ep, btl 1172 ompi/mca/pml/ob1/pml_ob1_sendreq.c if (bml_btl->btl->btl_register_mem && NULL == frag->local_handle) { btl 1221 ompi/mca/pml/ob1/pml_ob1_sendreq.c mca_btl_base_module_t* btl, btl 1249 ompi/mca/pml/ob1/pml_ob1_sendreq.c memcpy (frag->remote_handle, hdr + 1, btl->btl_registration_handle_size); btl 1251 ompi/mca/pml/ob1/pml_ob1_sendreq.c frag->rdma_bml = mca_bml_base_btl_array_find(&bml_endpoint->btl_rdma, btl); btl 378 ompi/mca/pml/ob1/pml_ob1_sendreq.h mca_btl_base_module_t* btl = bml_btl->btl; btl 379 ompi/mca/pml/ob1/pml_ob1_sendreq.h size_t eager_limit = btl->btl_eager_limit - sizeof(mca_pml_ob1_hdr_t); btl 383 ompi/mca/pml/ob1/pml_ob1_sendreq.h if (btl->btl_cuda_eager_limit && (sendreq->req_send.req_base.req_convertor.flags & CONVERTOR_CUDA)) { btl 384 ompi/mca/pml/ob1/pml_ob1_sendreq.h eager_limit = btl->btl_cuda_eager_limit - sizeof(mca_pml_ob1_hdr_t); btl 409 ompi/mca/pml/ob1/pml_ob1_sendreq.h if(OPAL_UNLIKELY(btl->btl_rndv_eager_limit < eager_limit)) btl 410 ompi/mca/pml/ob1/pml_ob1_sendreq.h size = btl->btl_rndv_eager_limit; btl 505 ompi/mca/pml/ob1/pml_ob1_sendreq.h mca_btl_base_module_t* btl, btl 79 opal/mca/btl/base/btl_base_error.c struct mca_btl_base_module_t* btl, btl 220 opal/mca/btl/base/btl_base_frame.c MCA_BASE_FRAMEWORK_DECLARE(opal, btl, "Byte Transport Layer", mca_btl_base_register, btl 592 opal/mca/btl/btl.h struct mca_btl_base_module_t* btl, btl 647 opal/mca/btl/btl.h struct mca_btl_base_module_t* btl btl 678 opal/mca/btl/btl.h struct mca_btl_base_module_t* btl, btl 699 opal/mca/btl/btl.h struct mca_btl_base_module_t* btl, btl 720 opal/mca/btl/btl.h struct mca_btl_base_module_t* btl, btl 738 opal/mca/btl/btl.h struct mca_btl_base_module_t* btl, btl 757 opal/mca/btl/btl.h struct mca_btl_base_module_t* btl, btl 779 opal/mca/btl/btl.h struct mca_btl_base_module_t* btl, btl 795 opal/mca/btl/btl.h struct mca_btl_base_module_t* btl, btl 876 opal/mca/btl/btl.h struct mca_btl_base_module_t* btl, struct mca_btl_base_registration_handle_t *handle); btl 896 opal/mca/btl/btl.h struct mca_btl_base_module_t* btl, btl 931 opal/mca/btl/btl.h struct mca_btl_base_module_t* btl, btl 974 opal/mca/btl/btl.h typedef int (*mca_btl_base_module_put_fn_t) (struct mca_btl_base_module_t *btl, btl 1011 opal/mca/btl/btl.h typedef int (*mca_btl_base_module_get_fn_t) (struct mca_btl_base_module_t *btl, btl 1052 opal/mca/btl/btl.h typedef int (*mca_btl_base_module_atomic_op64_fn_t) (struct mca_btl_base_module_t *btl, btl 1097 opal/mca/btl/btl.h typedef int (*mca_btl_base_module_atomic_fop64_fn_t) (struct mca_btl_base_module_t *btl, btl 1143 opal/mca/btl/btl.h typedef int (*mca_btl_base_module_atomic_cswap64_fn_t) (struct mca_btl_base_module_t *btl, btl 1159 opal/mca/btl/btl.h struct mca_btl_base_module_t* btl, btl 1183 opal/mca/btl/btl.h typedef int (*mca_btl_base_module_flush_fn_t) (struct mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint); btl 196 opal/mca/btl/ofi/btl_ofi.h struct mca_btl_ofi_module_t *btl; btl 221 opal/mca/btl/ofi/btl_ofi.h struct mca_btl_base_module_t *btl; btl 284 opal/mca/btl/ofi/btl_ofi.h int mca_btl_ofi_put (struct mca_btl_base_module_t *btl, btl 321 opal/mca/btl/ofi/btl_ofi.h int mca_btl_ofi_get (struct mca_btl_base_module_t *btl, btl 327 opal/mca/btl/ofi/btl_ofi.h int mca_btl_ofi_aop (struct mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint, btl 332 opal/mca/btl/ofi/btl_ofi.h int mca_btl_ofi_afop (struct mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint, btl 338 opal/mca/btl/ofi/btl_ofi.h int mca_btl_ofi_acswap (struct mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint, btl 344 opal/mca/btl/ofi/btl_ofi.h int mca_btl_ofi_flush (struct mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint); btl 346 opal/mca/btl/ofi/btl_ofi.h int mca_btl_ofi_finalize (mca_btl_base_module_t *btl); btl 33 opal/mca/btl/ofi/btl_ofi_atomics.c int mca_btl_ofi_afop (struct mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint, btl 43 opal/mca/btl/ofi/btl_ofi_atomics.c mca_btl_ofi_module_t *ofi_btl = (mca_btl_ofi_module_t *) btl; btl 56 opal/mca/btl/ofi/btl_ofi_atomics.c comp = mca_btl_ofi_rdma_completion_alloc(btl, endpoint, btl 87 opal/mca/btl/ofi/btl_ofi_atomics.c int mca_btl_ofi_aop (struct mca_btl_base_module_t *btl, mca_btl_base_endpoint_t *endpoint, btl 96 opal/mca/btl/ofi/btl_ofi_atomics.c mca_btl_ofi_module_t *ofi_btl = (mca_btl_ofi_module_t *) btl; btl 109 opal/mca/btl/ofi/btl_ofi_atomics.c comp = mca_btl_ofi_rdma_completion_alloc(btl, endpoint, btl 139 opal/mca/btl/ofi/btl_ofi_atomics.c int mca_btl_ofi_acswap (struct mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint, btl 149 opal/mca/btl/ofi/btl_ofi_atomics.c mca_btl_ofi_module_t *ofi_btl = (mca_btl_ofi_module_t *) btl; btl 159 opal/mca/btl/ofi/btl_ofi_atomics.c comp = mca_btl_ofi_rdma_completion_alloc(btl, endpoint, btl 340 opal/mca/btl/ofi/btl_ofi_context.c mca_btl_ofi_context_t *get_ofi_context(mca_btl_ofi_module_t *btl) btl 347 opal/mca/btl/ofi/btl_ofi_context.c OPAL_THREAD_LOCK(&btl->module_lock); btl 349 opal/mca/btl/ofi/btl_ofi_context.c my_context = &btl->contexts[cur_num]; btl 350 opal/mca/btl/ofi/btl_ofi_context.c cur_num = (cur_num + 1) %btl->num_contexts; btl 352 opal/mca/btl/ofi/btl_ofi_context.c OPAL_THREAD_UNLOCK(&btl->module_lock); btl 358 opal/mca/btl/ofi/btl_ofi_context.c return get_ofi_context_rr(btl); btl 364 opal/mca/btl/ofi/btl_ofi_context.c mca_btl_ofi_context_t *get_ofi_context_rr(mca_btl_ofi_module_t *btl) btl 367 opal/mca/btl/ofi/btl_ofi_context.c return &btl->contexts[rr_num++%btl->num_contexts]; btl 406 opal/mca/btl/ofi/btl_ofi_context.c rdma_comp->cbfunc (comp->btl, comp->endpoint, btl 411 opal/mca/btl/ofi/btl_ofi_context.c MCA_BTL_OFI_NUM_RDMA_DEC((mca_btl_ofi_module_t*) comp->btl); btl 415 opal/mca/btl/ofi/btl_ofi_context.c mca_btl_ofi_recv_frag((mca_btl_ofi_module_t*) comp->btl, btl 421 opal/mca/btl/ofi/btl_ofi_context.c MCA_BTL_OFI_NUM_SEND_DEC((mca_btl_ofi_module_t*) comp->btl); btl 71 opal/mca/btl/ofi/btl_ofi_endpoint.h mca_btl_ofi_context_t *get_ofi_context(mca_btl_ofi_module_t *btl); btl 72 opal/mca/btl/ofi/btl_ofi_endpoint.h mca_btl_ofi_context_t *get_ofi_context_rr(mca_btl_ofi_module_t *btl); btl 44 opal/mca/btl/ofi/btl_ofi_frag.c (mca_btl_base_module_t *btl, btl 52 opal/mca/btl/ofi/btl_ofi_frag.c comp->base.btl = btl; btl 65 opal/mca/btl/ofi/btl_ofi_frag.c mca_btl_base_module_t *btl, btl 69 opal/mca/btl/ofi/btl_ofi_frag.c mca_btl_ofi_module_t *ofi_btl = (mca_btl_ofi_module_t*) btl; btl 89 opal/mca/btl/ofi/btl_ofi_frag.c int mca_btl_ofi_free (mca_btl_base_module_t *btl, mca_btl_base_descriptor_t *des) btl 96 opal/mca/btl/ofi/btl_ofi_frag.c int mca_btl_ofi_send (mca_btl_base_module_t *btl, btl 103 opal/mca/btl/ofi/btl_ofi_frag.c mca_btl_ofi_module_t *ofi_btl = (mca_btl_ofi_module_t*) btl; btl 115 opal/mca/btl/ofi/btl_ofi_frag.c comp = mca_btl_ofi_frag_completion_alloc(btl, context, frag, btl 166 opal/mca/btl/ofi/btl_ofi_frag.c mca_btl_base_module_t *btl, btl 178 opal/mca/btl/ofi/btl_ofi_frag.c frag = (mca_btl_ofi_base_frag_t*) mca_btl_ofi_alloc(btl, endpoint, btl 33 opal/mca/btl/ofi/btl_ofi_frag.h mca_btl_base_module_t *btl, btl 37 opal/mca/btl/ofi/btl_ofi_frag.h int mca_btl_ofi_free (mca_btl_base_module_t *btl, mca_btl_base_descriptor_t *des); btl 39 opal/mca/btl/ofi/btl_ofi_frag.h int mca_btl_ofi_send (mca_btl_base_module_t *btl, btl 50 opal/mca/btl/ofi/btl_ofi_frag.h mca_btl_base_module_t *btl, btl 57 opal/mca/btl/ofi/btl_ofi_frag.h (mca_btl_base_module_t *btl, btl 70 opal/mca/btl/ofi/btl_ofi_frag.h frag->btl = ofi_btl; btl 82 opal/mca/btl/ofi/btl_ofi_frag.h mca_btl_ofi_module_t *ofi_btl = frag->btl; btl 38 opal/mca/btl/ofi/btl_ofi_module.c static int mca_btl_ofi_add_procs (mca_btl_base_module_t *btl, btl 51 opal/mca/btl/ofi/btl_ofi_module.c mca_btl_ofi_module_t *ofi_btl = (mca_btl_ofi_module_t *) btl; btl 105 opal/mca/btl/ofi/btl_ofi_module.c static int mca_btl_ofi_del_procs (mca_btl_base_module_t *btl, size_t nprocs, btl 109 opal/mca/btl/ofi/btl_ofi_module.c mca_btl_ofi_module_t *ofi_btl = (mca_btl_ofi_module_t *) btl; btl 185 opal/mca/btl/ofi/btl_ofi_module.c mca_btl_ofi_register_mem (struct mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint, void *base, btl 188 opal/mca/btl/ofi/btl_ofi_module.c mca_btl_ofi_module_t *ofi_module = (mca_btl_ofi_module_t *) btl; btl 213 opal/mca/btl/ofi/btl_ofi_module.c static int mca_btl_ofi_deregister_mem (mca_btl_base_module_t *btl, mca_btl_base_registration_handle_t *handle) btl 215 opal/mca/btl/ofi/btl_ofi_module.c mca_btl_ofi_module_t *ofi_module = (mca_btl_ofi_module_t *) btl; btl 229 opal/mca/btl/ofi/btl_ofi_module.c mca_btl_ofi_module_t *btl = (mca_btl_ofi_module_t*) reg_data; btl 232 opal/mca/btl/ofi/btl_ofi_module.c rc = fi_mr_reg(btl->domain, base, size, access_flags, 0, btl 244 opal/mca/btl/ofi/btl_ofi_module.c if (btl->use_virt_addr) { btl 272 opal/mca/btl/ofi/btl_ofi_module.c int mca_btl_ofi_finalize (mca_btl_base_module_t* btl) btl 275 opal/mca/btl/ofi/btl_ofi_module.c mca_btl_ofi_module_t *ofi_btl = (mca_btl_ofi_module_t *) btl; btl 278 opal/mca/btl/ofi/btl_ofi_module.c assert(btl); btl 321 opal/mca/btl/ofi/btl_ofi_module.c free (btl); btl 22 opal/mca/btl/ofi/btl_ofi_rdma.c mca_btl_base_module_t *btl, btl 31 opal/mca/btl/ofi/btl_ofi_rdma.c assert(btl); btl 40 opal/mca/btl/ofi/btl_ofi_rdma.c comp->base.btl = btl; btl 57 opal/mca/btl/ofi/btl_ofi_rdma.c int mca_btl_ofi_get (mca_btl_base_module_t *btl, mca_btl_base_endpoint_t *endpoint, void *local_address, btl 66 opal/mca/btl/ofi/btl_ofi_rdma.c mca_btl_ofi_module_t *ofi_btl = (mca_btl_ofi_module_t *) btl; btl 73 opal/mca/btl/ofi/btl_ofi_rdma.c comp = mca_btl_ofi_rdma_completion_alloc(btl, endpoint, btl 104 opal/mca/btl/ofi/btl_ofi_rdma.c int mca_btl_ofi_put (mca_btl_base_module_t *btl, mca_btl_base_endpoint_t *endpoint, void *local_address, btl 110 opal/mca/btl/ofi/btl_ofi_rdma.c mca_btl_ofi_module_t *ofi_btl = (mca_btl_ofi_module_t *) btl; btl 118 opal/mca/btl/ofi/btl_ofi_rdma.c comp = mca_btl_ofi_rdma_completion_alloc(btl, endpoint, btl 150 opal/mca/btl/ofi/btl_ofi_rdma.c int mca_btl_ofi_flush (mca_btl_base_module_t *btl, mca_btl_base_endpoint_t *endpoint) btl 152 opal/mca/btl/ofi/btl_ofi_rdma.c mca_btl_ofi_module_t *ofi_btl = (mca_btl_ofi_module_t *) btl; btl 23 opal/mca/btl/ofi/btl_ofi_rdma.h mca_btl_base_module_t *btl, btl 44 opal/mca/btl/portals4/btl_portals4.c mca_btl_portals4_register_mem(mca_btl_base_module_t *btl, btl 50 opal/mca/btl/portals4/btl_portals4.c int mca_btl_portals4_deregister_mem(mca_btl_base_module_t *btl, btl 459 opal/mca/btl/portals4/btl_portals4.c mca_btl_portals4_del_procs(struct mca_btl_base_module_t *btl, btl 464 opal/mca/btl/portals4/btl_portals4.c struct mca_btl_portals4_module_t* portals4_btl = (struct mca_btl_portals4_module_t*) btl; btl 695 opal/mca/btl/portals4/btl_portals4.c mca_btl_portals4_finalize(struct mca_btl_base_module_t *btl) btl 697 opal/mca/btl/portals4/btl_portals4.c struct mca_btl_portals4_module_t* portals4_btl = (struct mca_btl_portals4_module_t*) btl; btl 35 opal/mca/btl/portals4/btl_portals4_recv.c mca_btl_portals4_recv_enable(mca_btl_portals4_module_t *btl) btl 42 opal/mca/btl/portals4/btl_portals4_recv.c mca_btl_portals4_recv_block_init(btl); btl 44 opal/mca/btl/portals4/btl_portals4_recv.c mca_btl_portals4_recv_disable(btl); btl 47 opal/mca/btl/portals4/btl_portals4_recv.c opal_list_append(&(btl->portals_recv_blocks), btl 55 opal/mca/btl/portals4/btl_portals4_recv.c mca_btl_portals4_recv_disable(mca_btl_portals4_module_t *btl) btl 59 opal/mca/btl/portals4/btl_portals4_recv.c if (opal_list_get_size(&btl->portals_recv_blocks) > 0) { btl 61 opal/mca/btl/portals4/btl_portals4_recv.c (item = opal_list_remove_first(&btl->portals_recv_blocks))) { btl 72 opal/mca/btl/portals4/btl_portals4_recv.c mca_btl_portals4_recv_block_init(mca_btl_portals4_module_t *btl) btl 77 opal/mca/btl/portals4/btl_portals4_recv.c block->btl = btl; btl 28 opal/mca/btl/portals4/btl_portals4_recv.h mca_btl_portals4_module_t *btl; btl 41 opal/mca/btl/portals4/btl_portals4_recv.h int mca_btl_portals4_recv_enable(mca_btl_portals4_module_t *btl); btl 43 opal/mca/btl/portals4/btl_portals4_recv.h int mca_btl_portals4_recv_disable(mca_btl_portals4_module_t *btl); btl 59 opal/mca/btl/portals4/btl_portals4_recv.h mca_btl_portals4_recv_block_init(mca_btl_portals4_module_t *btl); btl 73 opal/mca/btl/portals4/btl_portals4_recv.h mca_btl_portals4_module_t *btl = block->btl; btl 83 opal/mca/btl/portals4/btl_portals4_recv.h me.min_free = btl->super.btl_eager_limit; btl 106 opal/mca/btl/portals4/btl_portals4_recv.h ret = PtlMEAppend(btl->portals_ni_h, btl 107 opal/mca/btl/portals4/btl_portals4_recv.h btl->recv_idx, btl 115 opal/mca/btl/portals4/btl_portals4_recv.h __FILE__, __LINE__, btl->interface_num, ret); btl 119 opal/mca/btl/portals4/btl_portals4_recv.h (void *)block, block->me_h, block->start, (unsigned int) block->length, btl->interface_num)); btl 49 opal/mca/btl/self/btl_self.c static int mca_btl_self_add_procs (struct mca_btl_base_module_t *btl, size_t nprocs, btl 75 opal/mca/btl/self/btl_self.c static int mca_btl_self_del_procs (struct mca_btl_base_module_t *btl, size_t nprocs, btl 96 opal/mca/btl/self/btl_self.c static int mca_btl_self_finalize(struct mca_btl_base_module_t* btl) btl 108 opal/mca/btl/self/btl_self.c static mca_btl_base_descriptor_t *mca_btl_self_alloc (struct mca_btl_base_module_t *btl, btl 118 opal/mca/btl/self/btl_self.c } else if (size <= btl->btl_max_send_size) { btl 139 opal/mca/btl/self/btl_self.c static int mca_btl_self_free (struct mca_btl_base_module_t *btl, mca_btl_base_descriptor_t *des) btl 152 opal/mca/btl/self/btl_self.c static struct mca_btl_base_descriptor_t *mca_btl_self_prepare_src (struct mca_btl_base_module_t* btl, btl 162 opal/mca/btl/self/btl_self.c frag = (mca_btl_self_frag_t *) mca_btl_self_alloc (btl, endpoint, order, buffer_len, flags); btl 176 opal/mca/btl/self/btl_self.c mca_btl_self_free (btl, &frag->base); btl 202 opal/mca/btl/self/btl_self.c static int mca_btl_self_send (struct mca_btl_base_module_t *btl, btl 212 opal/mca/btl/self/btl_self.c reg->cbfunc( btl, tag, des, reg->cbdata ); btl 216 opal/mca/btl/self/btl_self.c des->des_cbfunc( btl, endpoint, des, OPAL_SUCCESS ); btl 219 opal/mca/btl/self/btl_self.c mca_btl_self_free( btl, des ); btl 224 opal/mca/btl/self/btl_self.c static int mca_btl_self_sendi (struct mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint, btl 242 opal/mca/btl/self/btl_self.c (void) mca_btl_self_send (btl, endpoint, &des, tag); btl 246 opal/mca/btl/self/btl_self.c frag = mca_btl_self_prepare_src (btl, endpoint, convertor, order, header_size, &payload_size, btl 254 opal/mca/btl/self/btl_self.c (void) mca_btl_self_send (btl, endpoint, frag, tag); btl 258 opal/mca/btl/self/btl_self.c static int mca_btl_self_put (mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint, void *local_address, btl 265 opal/mca/btl/self/btl_self.c cbfunc (btl, endpoint, local_address, NULL, cbcontext, cbdata, OPAL_SUCCESS); btl 270 opal/mca/btl/self/btl_self.c static int mca_btl_self_get (mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint, void *local_address, btl 277 opal/mca/btl/self/btl_self.c cbfunc (btl, endpoint, local_address, NULL, cbcontext, cbdata, OPAL_SUCCESS); btl 79 opal/mca/btl/smcuda/btl_smcuda.c struct mca_btl_base_module_t* btl, struct mca_btl_base_endpoint_t *endpoint, void *base, btl 82 opal/mca/btl/smcuda/btl_smcuda.c static int mca_btl_smcuda_deregister_mem (struct mca_btl_base_module_t* btl, btl 108 opal/mca/btl/smcuda/btl_smcuda.c static void mca_btl_smcuda_send_cuda_ipc_request(struct mca_btl_base_module_t* btl, btl 525 opal/mca/btl/smcuda/btl_smcuda.c struct mca_btl_base_module_t* btl, btl 542 opal/mca/btl/smcuda/btl_smcuda.c smcuda_btl = (mca_btl_smcuda_t *)btl; btl 719 opal/mca/btl/smcuda/btl_smcuda.c struct mca_btl_base_module_t* btl, btl 748 opal/mca/btl/smcuda/btl_smcuda.c int mca_btl_smcuda_finalize(struct mca_btl_base_module_t* btl) btl 758 opal/mca/btl/smcuda/btl_smcuda.c struct mca_btl_base_module_t* btl, btl 761 opal/mca/btl/smcuda/btl_smcuda.c mca_btl_smcuda_t *smcuda_btl = (mca_btl_smcuda_t *)btl; btl 773 opal/mca/btl/smcuda/btl_smcuda.c struct mca_btl_base_module_t* btl, btl 800 opal/mca/btl/smcuda/btl_smcuda.c struct mca_btl_base_module_t* btl, btl 816 opal/mca/btl/smcuda/btl_smcuda.c struct mca_btl_base_module_t* btl, btl 899 opal/mca/btl/smcuda/btl_smcuda.c int mca_btl_smcuda_sendi( struct mca_btl_base_module_t* btl, btl 920 opal/mca/btl/smcuda/btl_smcuda.c mca_btl_smcuda_send_cuda_ipc_request(btl, endpoint); btl 925 opal/mca/btl/smcuda/btl_smcuda.c *descriptor = mca_btl_smcuda_alloc(btl, endpoint, order, payload_size+header_size, flags); btl 987 opal/mca/btl/smcuda/btl_smcuda.c *descriptor = mca_btl_smcuda_alloc( btl, endpoint, order, btl 998 opal/mca/btl/smcuda/btl_smcuda.c int mca_btl_smcuda_send( struct mca_btl_base_module_t* btl, btl 1012 opal/mca/btl/smcuda/btl_smcuda.c mca_btl_smcuda_send_cuda_ipc_request(btl, endpoint); btl 1044 opal/mca/btl/smcuda/btl_smcuda.c struct mca_btl_base_module_t* btl, struct mca_btl_base_endpoint_t *endpoint, void *base, btl 1047 opal/mca/btl/smcuda/btl_smcuda.c mca_btl_smcuda_t *smcuda_module = (mca_btl_smcuda_t *) btl; btl 1065 opal/mca/btl/smcuda/btl_smcuda.c static int mca_btl_smcuda_deregister_mem (struct mca_btl_base_module_t* btl, btl 1068 opal/mca/btl/smcuda/btl_smcuda.c mca_btl_smcuda_t *smcuda_module = (mca_btl_smcuda_t *) btl; btl 1077 opal/mca/btl/smcuda/btl_smcuda.c int mca_btl_smcuda_get_cuda (struct mca_btl_base_module_t *btl, btl 1169 opal/mca/btl/smcuda/btl_smcuda.c cbfunc (btl, ep, local_address, local_handle, cbcontext, cbdata, OPAL_SUCCESS); btl 1170 opal/mca/btl/smcuda/btl_smcuda.c mca_btl_smcuda_free(btl, (mca_btl_base_descriptor_t *)frag); btl 1187 opal/mca/btl/smcuda/btl_smcuda.c static void mca_btl_smcuda_send_cuda_ipc_request(struct mca_btl_base_module_t* btl, btl 1262 opal/mca/btl/smcuda/btl_smcuda.c void mca_btl_smcuda_dump(struct mca_btl_base_module_t* btl, btl 1269 opal/mca/btl/smcuda/btl_smcuda.c (void*) btl, (void*) endpoint, btl 351 opal/mca/btl/smcuda/btl_smcuda.h struct mca_btl_base_module_t* btl, btl 363 opal/mca/btl/smcuda/btl_smcuda.h struct mca_btl_base_module_t* btl btl 382 opal/mca/btl/smcuda/btl_smcuda.h struct mca_btl_base_module_t* btl, btl 400 opal/mca/btl/smcuda/btl_smcuda.h struct mca_btl_base_module_t* btl, btl 414 opal/mca/btl/smcuda/btl_smcuda.h struct mca_btl_base_module_t* btl, btl 428 opal/mca/btl/smcuda/btl_smcuda.h struct mca_btl_base_module_t* btl, btl 440 opal/mca/btl/smcuda/btl_smcuda.h struct mca_btl_base_module_t* btl, btl 456 opal/mca/btl/smcuda/btl_smcuda.h extern int mca_btl_smcuda_sendi( struct mca_btl_base_module_t* btl, btl 474 opal/mca/btl/smcuda/btl_smcuda.h struct mca_btl_base_module_t* btl, btl 484 opal/mca/btl/smcuda/btl_smcuda.h int mca_btl_smcuda_get_cuda (struct mca_btl_base_module_t *btl, btl 516 opal/mca/btl/smcuda/btl_smcuda.h extern void mca_btl_smcuda_dump(struct mca_btl_base_module_t* btl, btl 627 opal/mca/btl/smcuda/btl_smcuda_component.c static void mca_btl_smcuda_send_cuda_ipc_ack(struct mca_btl_base_module_t* btl, btl 681 opal/mca/btl/smcuda/btl_smcuda_component.c static void btl_smcuda_control(mca_btl_base_module_t* btl, btl 689 opal/mca/btl/smcuda/btl_smcuda_component.c mca_btl_smcuda_t *smcuda_btl = (mca_btl_smcuda_t *)btl; btl 723 opal/mca/btl/smcuda/btl_smcuda_component.c mca_btl_smcuda_send_cuda_ipc_ack(btl, endpoint, 0); btl 787 opal/mca/btl/smcuda/btl_smcuda_component.c mca_btl_smcuda_send_cuda_ipc_ack(btl, endpoint, 1); btl 63 opal/mca/btl/tcp/btl_tcp.c int mca_btl_tcp_add_procs( struct mca_btl_base_module_t* btl, btl 69 opal/mca/btl/tcp/btl_tcp.c mca_btl_tcp_module_t* tcp_btl = (mca_btl_tcp_module_t*)btl; btl 145 opal/mca/btl/tcp/btl_tcp.c int mca_btl_tcp_del_procs(struct mca_btl_base_module_t* btl, btl 150 opal/mca/btl/tcp/btl_tcp.c mca_btl_tcp_module_t* tcp_btl = (mca_btl_tcp_module_t*)btl; btl 172 opal/mca/btl/tcp/btl_tcp.c struct mca_btl_base_module_t* btl, btl 180 opal/mca/btl/tcp/btl_tcp.c if(size <= btl->btl_eager_limit) { btl 182 opal/mca/btl/tcp/btl_tcp.c } else if (size <= btl->btl_max_send_size) { btl 196 opal/mca/btl/tcp/btl_tcp.c frag->btl = (mca_btl_tcp_module_t*)btl; btl 206 opal/mca/btl/tcp/btl_tcp.c struct mca_btl_base_module_t* btl, btl 222 opal/mca/btl/tcp/btl_tcp.c struct mca_btl_base_module_t* btl, btl 243 opal/mca/btl/tcp/btl_tcp.c if (max_data+reserve <= btl->btl_eager_limit) { btl 270 opal/mca/btl/tcp/btl_tcp.c mca_btl_tcp_free(btl, &frag->base); btl 283 opal/mca/btl/tcp/btl_tcp.c mca_btl_tcp_free(btl, &frag->base); btl 308 opal/mca/btl/tcp/btl_tcp.c int mca_btl_tcp_send( struct mca_btl_base_module_t* btl, btl 313 opal/mca/btl/tcp/btl_tcp.c mca_btl_tcp_module_t* tcp_btl = (mca_btl_tcp_module_t*) btl; btl 317 opal/mca/btl/tcp/btl_tcp.c frag->btl = tcp_btl; btl 339 opal/mca/btl/tcp/btl_tcp.c static void fake_rdma_complete (mca_btl_base_module_t *btl, mca_btl_base_endpoint_t *endpoint, btl 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, btl 352 opal/mca/btl/tcp/btl_tcp.c int mca_btl_tcp_put (mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint, void *local_address, btl 357 opal/mca/btl/tcp/btl_tcp.c mca_btl_tcp_module_t* tcp_btl = (mca_btl_tcp_module_t*) btl; btl 389 opal/mca/btl/tcp/btl_tcp.c frag->btl = tcp_btl; btl 418 opal/mca/btl/tcp/btl_tcp.c int mca_btl_tcp_get (mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint, void *local_address, btl 423 opal/mca/btl/tcp/btl_tcp.c mca_btl_tcp_module_t* tcp_btl = (mca_btl_tcp_module_t*) btl; btl 456 opal/mca/btl/tcp/btl_tcp.c frag->btl = tcp_btl; btl 479 opal/mca/btl/tcp/btl_tcp.c int mca_btl_tcp_finalize(struct mca_btl_base_module_t* btl) btl 481 opal/mca/btl/tcp/btl_tcp.c mca_btl_tcp_module_t* tcp_btl = (mca_btl_tcp_module_t*) btl; btl 501 opal/mca/btl/tcp/btl_tcp.c mca_btl_tcp_module_t* btl = (mca_btl_tcp_module_t*)base_btl; btl 507 opal/mca/btl/tcp/btl_tcp.c OPAL_NAME_PRINT(OPAL_PROC_MY_NAME), (void*)btl, btl->tcp_ifkindex, btl 509 opal/mca/btl/tcp/btl_tcp.c btl->tcp_bytes_sent, btl->btl_bytes_recv, btl 511 opal/mca/btl/tcp/btl_tcp.c btl->super.btl_latency, btl->super.btl_bandwidth); btl 519 opal/mca/btl/tcp/btl_tcp.c OPAL_THREAD_LOCK(&btl->tcp_endpoints_mutex); btl 520 opal/mca/btl/tcp/btl_tcp.c for(item = opal_list_get_first(&btl->tcp_endpoints); btl 521 opal/mca/btl/tcp/btl_tcp.c item != opal_list_get_end(&btl->tcp_endpoints); btl 525 opal/mca/btl/tcp/btl_tcp.c OPAL_THREAD_UNLOCK(&btl->tcp_endpoints_mutex); btl 211 opal/mca/btl/tcp/btl_tcp.h struct mca_btl_base_module_t* btl btl 228 opal/mca/btl/tcp/btl_tcp.h struct mca_btl_base_module_t* btl, btl 247 opal/mca/btl/tcp/btl_tcp.h struct mca_btl_base_module_t* btl, btl 264 opal/mca/btl/tcp/btl_tcp.h struct mca_btl_base_module_t* btl, btl 275 opal/mca/btl/tcp/btl_tcp.h int mca_btl_tcp_put (mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint, void *local_address, btl 285 opal/mca/btl/tcp/btl_tcp.h int mca_btl_tcp_get (mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint, void *local_address, btl 300 opal/mca/btl/tcp/btl_tcp.h struct mca_btl_base_module_t* btl, btl 315 opal/mca/btl/tcp/btl_tcp.h struct mca_btl_base_module_t* btl, btl 334 opal/mca/btl/tcp/btl_tcp.h struct mca_btl_base_module_t* btl, btl 344 opal/mca/btl/tcp/btl_tcp.h mca_btl_tcp_dump(struct mca_btl_base_module_t* btl, btl 495 opal/mca/btl/tcp/btl_tcp_component.c struct mca_btl_tcp_module_t* btl; btl 548 opal/mca/btl/tcp/btl_tcp_component.c btl = (struct mca_btl_tcp_module_t *)malloc(sizeof(mca_btl_tcp_module_t)); btl 549 opal/mca/btl/tcp/btl_tcp_component.c if(NULL == btl) btl 551 opal/mca/btl/tcp/btl_tcp_component.c memcpy(btl, &mca_btl_tcp_module, sizeof(mca_btl_tcp_module)); btl 552 opal/mca/btl/tcp/btl_tcp_component.c OBJ_CONSTRUCT(&btl->tcp_endpoints, opal_list_t); btl 553 opal/mca/btl/tcp/btl_tcp_component.c OBJ_CONSTRUCT(&btl->tcp_endpoints_mutex, opal_mutex_t); btl 554 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_component.tcp_btls[mca_btl_tcp_component.tcp_num_btls++] = btl; btl 557 opal/mca/btl/tcp/btl_tcp_component.c btl->tcp_ifkindex = (uint16_t) if_kindex; btl 559 opal/mca/btl/tcp/btl_tcp_component.c btl->tcp_bytes_recv = 0; btl 560 opal/mca/btl/tcp/btl_tcp_component.c btl->tcp_bytes_sent = 0; btl 561 opal/mca/btl/tcp/btl_tcp_component.c btl->tcp_send_handler = 0; btl 564 opal/mca/btl/tcp/btl_tcp_component.c memcpy(&btl->tcp_ifaddr, &addr, sizeof(struct sockaddr_storage)); btl 568 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_param_register_uint(param, NULL, btl->super.btl_bandwidth, OPAL_INFO_LVL_5, &btl->super.btl_bandwidth); btl 572 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_param_register_uint(param, NULL, btl->super.btl_latency, OPAL_INFO_LVL_5, &btl->super.btl_latency); btl 574 opal/mca/btl/tcp/btl_tcp_component.c btl->super.btl_bandwidth >>= 1; btl 575 opal/mca/btl/tcp/btl_tcp_component.c btl->super.btl_latency <<= 1; btl 580 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_param_register_uint(param, NULL, btl->super.btl_bandwidth, OPAL_INFO_LVL_5, &btl->super.btl_bandwidth); btl 584 opal/mca/btl/tcp/btl_tcp_component.c mca_btl_tcp_param_register_uint(param, NULL, btl->super.btl_latency, OPAL_INFO_LVL_5, &btl->super.btl_latency); btl 591 opal/mca/btl/tcp/btl_tcp_component.c if (0 == btl->super.btl_bandwidth) { btl 593 opal/mca/btl/tcp/btl_tcp_component.c btl->super.btl_bandwidth = (speed == 0) ? MCA_BTL_TCP_BTL_BANDWIDTH : speed; btl 595 opal/mca/btl/tcp/btl_tcp_component.c btl->super.btl_bandwidth >>= 1; btl 599 opal/mca/btl/tcp/btl_tcp_component.c if (0 == btl->super.btl_latency) { btl 600 opal/mca/btl/tcp/btl_tcp_component.c btl->super.btl_latency = MCA_BTL_TCP_BTL_LATENCY; btl 602 opal/mca/btl/tcp/btl_tcp_component.c btl->super.btl_latency <<= 1; btl 608 opal/mca/btl/tcp/btl_tcp_component.c (void*)btl, if_name, (int) btl->tcp_ifkindex, i, btl 609 opal/mca/btl/tcp/btl_tcp_component.c opal_net_get_hostname((struct sockaddr*)&btl->tcp_ifaddr), btl 610 opal/mca/btl/tcp/btl_tcp_component.c (btl->tcp_ifaddr.ss_family == AF_INET) ? "IPv4" : "IPv6", btl 611 opal/mca/btl/tcp/btl_tcp_component.c btl->super.btl_bandwidth, btl->super.btl_latency); btl 1181 opal/mca/btl/tcp/btl_tcp_component.c struct mca_btl_tcp_module_t *btl = mca_btl_tcp_component.tcp_btls[i]; btl 1182 opal/mca/btl/tcp/btl_tcp_component.c struct sockaddr *addr = (struct sockaddr*)&(btl->tcp_ifaddr); btl 1191 opal/mca/btl/tcp/btl_tcp_component.c addrs[i].addr_ifkindex = btl->tcp_ifkindex; btl 1195 opal/mca/btl/tcp/btl_tcp_component.c (int)i, btl->tcp_ifkindex, btl 1205 opal/mca/btl/tcp/btl_tcp_component.c addrs[i].addr_ifkindex = btl->tcp_ifkindex; btl 1209 opal/mca/btl/tcp/btl_tcp_component.c (int)i, btl->tcp_ifkindex, btl 356 opal/mca/btl/tcp/btl_tcp_endpoint.c frag->base.des_cbfunc(&frag->btl->super, frag->endpoint, &frag->base, frag->rc); btl 549 opal/mca/btl/tcp/btl_tcp_endpoint.c frag->base.des_cbfunc(&frag->btl->super, frag->endpoint, &frag->base, OPAL_ERR_UNREACH); btl 979 opal/mca/btl/tcp/btl_tcp_endpoint.c reg->cbfunc(&frag->btl->super, frag->hdr.base.tag, &frag->base, reg->cbdata); btl 1050 opal/mca/btl/tcp/btl_tcp_endpoint.c frag->base.des_cbfunc(&frag->btl->super, frag->endpoint, &frag->base, frag->rc); btl 52 opal/mca/btl/tcp/btl_tcp_frag.h struct mca_btl_tcp_module_t* btl; btl 116 opal/mca/btl/tcp/btl_tcp_frag.h frag->btl = ep->endpoint_btl; \ btl 60 opal/mca/btl/template/btl_template.c struct mca_btl_base_module_t* btl, btl 66 opal/mca/btl/template/btl_template.c mca_btl_template_module_t* template_btl = (mca_btl_template_module_t*)btl; btl 121 opal/mca/btl/template/btl_template.c int mca_btl_template_del_procs(struct mca_btl_base_module_t* btl, btl 136 opal/mca/btl/template/btl_template.c struct mca_btl_base_module_t* btl, btl 153 opal/mca/btl/template/btl_template.c struct mca_btl_base_module_t* btl, btl 159 opal/mca/btl/template/btl_template.c mca_btl_template_module_t* template_btl = (mca_btl_template_module_t*) btl; btl 162 opal/mca/btl/template/btl_template.c if(size <= btl->btl_eager_limit){ btl 182 opal/mca/btl/template/btl_template.c struct mca_btl_base_module_t* btl, btl 190 opal/mca/btl/template/btl_template.c MCA_BTL_TEMPLATE_FRAG_RETURN_USER(btl, frag); btl 191 opal/mca/btl/template/btl_template.c } else if(frag->size == btl->btl_eager_limit){ btl 192 opal/mca/btl/template/btl_template.c MCA_BTL_TEMPLATE_FRAG_RETURN_EAGER(btl, frag); btl 193 opal/mca/btl/template/btl_template.c } else if(frag->size == btl->btl_max_send_size) { btl 194 opal/mca/btl/template/btl_template.c MCA_BTL_TEMPLATE_FRAG_RETURN_EAGER(btl, frag); btl 209 opal/mca/btl/template/btl_template.c struct mca_btl_base_module_t* btl, btl 229 opal/mca/btl/template/btl_template.c if (max_data+reserve <= btl->btl_eager_limit) { btl 231 opal/mca/btl/template/btl_template.c MCA_BTL_TEMPLATE_FRAG_ALLOC_EAGER(btl, frag); btl 242 opal/mca/btl/template/btl_template.c MCA_BTL_TEMPLATE_FRAG_RETURN_EAGER(btl, frag); btl 254 opal/mca/btl/template/btl_template.c MCA_BTL_TEMPLATE_FRAG_ALLOC_MAX(btl, frag); btl 268 opal/mca/btl/template/btl_template.c MCA_BTL_TEMPLATE_FRAG_RETURN_MAX(btl, frag); btl 291 opal/mca/btl/template/btl_template.c struct mca_btl_base_module_t* btl, btl 313 opal/mca/btl/template/btl_template.c int mca_btl_template_put (struct mca_btl_base_module_t *btl, btl 334 opal/mca/btl/template/btl_template.c int mca_btl_template_get (struct mca_btl_base_module_t *btl, btl 365 opal/mca/btl/template/btl_template.c struct mca_btl_base_module_t* btl, struct mca_btl_base_endpoint_t *endpoint, void *base, btl 384 opal/mca/btl/template/btl_template.c int mca_btl_template_deregister_mem (struct mca_btl_base_module_t* btl, btl 397 opal/mca/btl/template/btl_template.c int mca_btl_template_finalize(struct mca_btl_base_module_t* btl) btl 399 opal/mca/btl/template/btl_template.c mca_btl_template_module_t* template_btl = (mca_btl_template_module_t*) btl; btl 130 opal/mca/btl/template/btl_template.h struct mca_btl_base_module_t* btl btl 147 opal/mca/btl/template/btl_template.h struct mca_btl_base_module_t* btl, btl 166 opal/mca/btl/template/btl_template.h struct mca_btl_base_module_t* btl, btl 183 opal/mca/btl/template/btl_template.h struct mca_btl_base_module_t* btl, btl 221 opal/mca/btl/template/btl_template.h int mca_btl_template_put (struct mca_btl_base_module_t *btl, btl 258 opal/mca/btl/template/btl_template.h int mca_btl_template_get (struct mca_btl_base_module_t *btl, btl 284 opal/mca/btl/template/btl_template.h struct mca_btl_base_module_t* btl, struct mca_btl_base_endpoint_t *endpoint, void *base, btl 298 opal/mca/btl/template/btl_template.h int mca_btl_template_deregister_mem (struct mca_btl_base_module_t* btl, btl 311 opal/mca/btl/template/btl_template.h struct mca_btl_base_module_t* btl, btl 326 opal/mca/btl/template/btl_template.h struct mca_btl_base_module_t* btl, btl 341 opal/mca/btl/template/btl_template.h struct mca_btl_base_module_t* btl, btl 360 opal/mca/btl/template/btl_template.h struct mca_btl_base_module_t* btl, btl 66 opal/mca/btl/template/btl_template_frag.h #define MCA_BTL_TEMPLATE_FRAG_ALLOC_EAGER(btl, frag) \ btl 69 opal/mca/btl/template/btl_template_frag.h opal_free_list_get (&((mca_btl_template_module_t*)btl)->template_frag_eager); \ btl 72 opal/mca/btl/template/btl_template_frag.h #define MCA_BTL_TEMPLATE_FRAG_RETURN_EAGER(btl, frag) \ btl 74 opal/mca/btl/template/btl_template_frag.h opal_free_list_return (&((mca_btl_template_module_t*)btl)->template_frag_eager, \ btl 78 opal/mca/btl/template/btl_template_frag.h #define MCA_BTL_TEMPLATE_FRAG_ALLOC_MAX(btl, frag) \ btl 81 opal/mca/btl/template/btl_template_frag.h opal_free_list_get (&((mca_btl_template_module_t*)btl)->template_frag_max); \ btl 84 opal/mca/btl/template/btl_template_frag.h #define MCA_BTL_TEMPLATE_FRAG_RETURN_MAX(btl, frag) \ btl 86 opal/mca/btl/template/btl_template_frag.h opal_free_list_return (&((mca_btl_template_module_t*)btl)->template_frag_max, \ btl 91 opal/mca/btl/template/btl_template_frag.h #define MCA_BTL_TEMPLATE_FRAG_ALLOC_USER(btl, frag) \ btl 94 opal/mca/btl/template/btl_template_frag.h opal_free_list_get (&((mca_btl_template_module_t*)btl)->template_frag_user); \ btl 97 opal/mca/btl/template/btl_template_frag.h #define MCA_BTL_TEMPLATE_FRAG_RETURN_USER(btl, frag) \ btl 99 opal/mca/btl/template/btl_template_frag.h opal_free_list_return (&((mca_btl_template_module_t*)btl)->template_frag_user, \ btl 204 opal/mca/btl/uct/btl_uct.h int mca_btl_uct_put (struct mca_btl_base_module_t *btl, btl 241 opal/mca/btl/uct/btl_uct.h int mca_btl_uct_get (struct mca_btl_base_module_t *btl, btl 254 opal/mca/btl/uct/btl_uct.h int mca_btl_uct_aop (struct mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint, btl 259 opal/mca/btl/uct/btl_uct.h int mca_btl_uct_afop (struct mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint, btl 265 opal/mca/btl/uct/btl_uct.h int mca_btl_uct_acswap (struct mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint, btl 271 opal/mca/btl/uct/btl_uct.h int mca_btl_uct_flush (struct mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint); btl 272 opal/mca/btl/uct/btl_uct.h int mca_btl_uct_flush_thread (mca_btl_base_module_t *btl); btl 274 opal/mca/btl/uct/btl_uct.h int mca_btl_uct_finalize (mca_btl_base_module_t *btl); btl 22 opal/mca/btl/uct/btl_uct_am.c mca_btl_base_descriptor_t *mca_btl_uct_alloc (mca_btl_base_module_t *btl, mca_btl_base_endpoint_t *endpoint, btl 25 opal/mca/btl/uct/btl_uct_am.c mca_btl_uct_module_t *uct_btl = (mca_btl_uct_module_t *) btl; btl 73 opal/mca/btl/uct/btl_uct_am.c struct mca_btl_base_descriptor_t *mca_btl_uct_prepare_src (mca_btl_base_module_t *btl, btl 79 opal/mca/btl/uct/btl_uct_am.c mca_btl_uct_module_t *uct_btl = (mca_btl_uct_module_t *) btl; btl 86 opal/mca/btl/uct/btl_uct_am.c frag = (mca_btl_uct_base_frag_t *) mca_btl_uct_alloc (btl, endpoint, order, total_size, flags); btl 126 opal/mca/btl/uct/btl_uct_am.c int mca_btl_uct_free (mca_btl_base_module_t *btl, mca_btl_base_descriptor_t *des) btl 231 opal/mca/btl/uct/btl_uct_am.c int mca_btl_uct_send (mca_btl_base_module_t *btl, mca_btl_base_endpoint_t *endpoint, mca_btl_base_descriptor_t *descriptor, btl 234 opal/mca/btl/uct/btl_uct_am.c mca_btl_uct_module_t *uct_btl = (mca_btl_uct_module_t *) btl; btl 288 opal/mca/btl/uct/btl_uct_am.c int mca_btl_uct_sendi (mca_btl_base_module_t *btl, mca_btl_base_endpoint_t *endpoint, opal_convertor_t *convertor, btl 292 opal/mca/btl/uct/btl_uct_am.c mca_btl_uct_module_t *uct_btl = (mca_btl_uct_module_t *) btl; btl 305 opal/mca/btl/uct/btl_uct_am.c *descriptor = mca_btl_uct_alloc (btl, endpoint, order, total_size, flags); btl 336 opal/mca/btl/uct/btl_uct_am.c *descriptor = mca_btl_uct_alloc (btl, endpoint, order, total_size, flags); btl 17 opal/mca/btl/uct/btl_uct_am.h struct mca_btl_base_descriptor_t *mca_btl_uct_prepare_src (mca_btl_base_module_t *btl, btl 23 opal/mca/btl/uct/btl_uct_am.h int mca_btl_uct_sendi (mca_btl_base_module_t *btl, mca_btl_base_endpoint_t *endpoint, opal_convertor_t *convertor, btl 27 opal/mca/btl/uct/btl_uct_am.h int mca_btl_uct_send (mca_btl_base_module_t *btl, mca_btl_base_endpoint_t *endpoint, mca_btl_base_descriptor_t *descriptor, btl 32 opal/mca/btl/uct/btl_uct_am.h mca_btl_base_descriptor_t *mca_btl_uct_alloc (mca_btl_base_module_t *btl, mca_btl_base_endpoint_t *endpoint, btl 35 opal/mca/btl/uct/btl_uct_am.h int mca_btl_uct_free (mca_btl_base_module_t *btl, mca_btl_base_descriptor_t *des); btl 26 opal/mca/btl/uct/btl_uct_amo.c int mca_btl_uct_afop (struct mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint, btl 32 opal/mca/btl/uct/btl_uct_amo.c mca_btl_uct_module_t *uct_btl = (mca_btl_uct_module_t *) btl; btl 118 opal/mca/btl/uct/btl_uct_amo.c int mca_btl_uct_aop (struct mca_btl_base_module_t *btl, mca_btl_base_endpoint_t *endpoint, btl 129 opal/mca/btl/uct/btl_uct_amo.c return mca_btl_uct_afop (btl, endpoint, &result, remote_address, NULL, remote_handle, op, btl 133 opal/mca/btl/uct/btl_uct_amo.c int mca_btl_uct_acswap (struct mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint, btl 138 opal/mca/btl/uct/btl_uct_amo.c mca_btl_uct_module_t *uct_btl = (mca_btl_uct_module_t *) btl; btl 136 opal/mca/btl/uct/btl_uct_device_context.h comp->cbfunc (comp->btl, comp->endpoint, comp->local_address, comp->local_handle, btl 24 opal/mca/btl/uct/btl_uct_frag.h frag->btl = uct_btl; btl 36 opal/mca/btl/uct/btl_uct_frag.h mca_btl_uct_module_t *uct_btl = frag->btl; btl 67 opal/mca/btl/uct/btl_uct_module.c static int mca_btl_uct_add_procs (mca_btl_base_module_t *btl, btl 72 opal/mca/btl/uct/btl_uct_module.c mca_btl_uct_module_t *uct_module = (mca_btl_uct_module_t *) btl; btl 95 opal/mca/btl/uct/btl_uct_module.c btl->btl_eager_limit, opal_cache_line_size, btl 100 opal/mca/btl/uct/btl_uct_module.c btl->btl_max_send_size, opal_cache_line_size, 0, 128, 8, btl 109 opal/mca/btl/uct/btl_uct_module.c peers[i] = mca_btl_uct_get_ep (btl, opal_procs[i]); btl 120 opal/mca/btl/uct/btl_uct_module.c static int mca_btl_uct_del_procs (mca_btl_base_module_t *btl, size_t nprocs, btl 123 opal/mca/btl/uct/btl_uct_module.c mca_btl_uct_module_t *uct_module = (mca_btl_uct_module_t *) btl; btl 165 opal/mca/btl/uct/btl_uct_module.c mca_btl_uct_register_mem (struct mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint, void *base, btl 168 opal/mca/btl/uct/btl_uct_module.c mca_btl_uct_module_t *uct_module = (mca_btl_uct_module_t *) btl; btl 193 opal/mca/btl/uct/btl_uct_module.c static int mca_btl_uct_deregister_mem (mca_btl_base_module_t *btl, mca_btl_base_registration_handle_t *handle) btl 195 opal/mca/btl/uct/btl_uct_module.c mca_btl_uct_module_t *uct_module = (mca_btl_uct_module_t *) btl; btl 263 opal/mca/btl/uct/btl_uct_module.c int mca_btl_uct_finalize (mca_btl_base_module_t* btl) btl 265 opal/mca/btl/uct/btl_uct_module.c mca_btl_uct_module_t *uct_module = (mca_btl_uct_module_t *) btl; btl 43 opal/mca/btl/uct/btl_uct_rdma.c comp->btl = &uct_btl->super; btl 68 opal/mca/btl/uct/btl_uct_rdma.c int mca_btl_uct_get (mca_btl_base_module_t *btl, mca_btl_base_endpoint_t *endpoint, void *local_address, btl 73 opal/mca/btl/uct/btl_uct_rdma.c mca_btl_uct_module_t *uct_btl = (mca_btl_uct_module_t *) btl; btl 124 opal/mca/btl/uct/btl_uct_rdma.c cbfunc (btl, endpoint, local_address, local_handle, cbcontext, cbdata, OPAL_SUCCESS); btl 155 opal/mca/btl/uct/btl_uct_rdma.c int mca_btl_uct_put (mca_btl_base_module_t *btl, mca_btl_base_endpoint_t *endpoint, void *local_address, btl 160 opal/mca/btl/uct/btl_uct_rdma.c mca_btl_uct_module_t *uct_btl = (mca_btl_uct_module_t *) btl; btl 231 opal/mca/btl/uct/btl_uct_rdma.c cbfunc (btl, endpoint, local_address, local_handle, cbcontext, cbdata, OPAL_SUCCESS); btl 245 opal/mca/btl/uct/btl_uct_rdma.c int mca_btl_uct_flush (mca_btl_base_module_t *btl, mca_btl_base_endpoint_t *endpoint) btl 247 opal/mca/btl/uct/btl_uct_rdma.c mca_btl_uct_module_t *uct_btl = (mca_btl_uct_module_t *) btl; btl 281 opal/mca/btl/uct/btl_uct_rdma.c int mca_btl_uct_flush_thread (mca_btl_base_module_t *btl) btl 283 opal/mca/btl/uct/btl_uct_rdma.c mca_btl_uct_module_t *uct_btl = (mca_btl_uct_module_t *) btl; btl 22 opal/mca/btl/uct/btl_uct_rdma.h mca_btl_uct_uct_completion_t *mca_btl_uct_uct_completion_alloc (mca_btl_uct_module_t *btl, mca_btl_base_endpoint_t *endpoint, btl 203 opal/mca/btl/uct/btl_uct_types.h struct mca_btl_base_module_t *btl; btl 245 opal/mca/btl/uct/btl_uct_types.h struct mca_btl_uct_module_t *btl; btl 340 opal/mca/btl/ugni/btl_ugni.h int mca_btl_ugni_flush (mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint); btl 355 opal/mca/btl/ugni/btl_ugni.h mca_btl_ugni_add_procs (struct mca_btl_base_module_t* btl, btl 373 opal/mca/btl/ugni/btl_ugni.h mca_btl_ugni_del_procs (struct mca_btl_base_module_t *btl, btl 391 opal/mca/btl/ugni/btl_ugni.h mca_btl_ugni_send (struct mca_btl_base_module_t *btl, btl 413 opal/mca/btl/ugni/btl_ugni.h mca_btl_ugni_sendi (struct mca_btl_base_module_t *btl, btl 421 opal/mca/btl/ugni/btl_ugni.h int mca_btl_ugni_get (mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint, void *local_address, btl 426 opal/mca/btl/ugni/btl_ugni.h int mca_btl_ugni_put (mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint, void *local_address, btl 431 opal/mca/btl/ugni/btl_ugni.h int mca_btl_ugni_aop (struct mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint, btl 436 opal/mca/btl/ugni/btl_ugni.h int mca_btl_ugni_afop (struct mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint, btl 442 opal/mca/btl/ugni/btl_ugni.h int mca_btl_ugni_acswap (struct mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint, btl 451 opal/mca/btl/ugni/btl_ugni.h mca_btl_ugni_alloc(struct mca_btl_base_module_t *btl, btl 498 opal/mca/btl/ugni/btl_ugni.h int mca_btl_ugni_spawn_progress_thread(struct mca_btl_base_module_t* btl); btl 31 opal/mca/btl/ugni/btl_ugni_add_procs.c int mca_btl_ugni_add_procs (struct mca_btl_base_module_t* btl, size_t nprocs, btl 35 opal/mca/btl/ugni/btl_ugni_add_procs.c mca_btl_ugni_module_t *ugni_module = (mca_btl_ugni_module_t *) btl; btl 62 opal/mca/btl/ugni/btl_ugni_add_procs.c peers[i] = mca_btl_ugni_get_ep (btl, procs[i]); btl 157 opal/mca/btl/ugni/btl_ugni_add_procs.c mca_btl_ugni_spawn_progress_thread(btl); btl 168 opal/mca/btl/ugni/btl_ugni_add_procs.c int mca_btl_ugni_del_procs (struct mca_btl_base_module_t *btl, btl 171 opal/mca/btl/ugni/btl_ugni_add_procs.c mca_btl_ugni_module_t *ugni_module = (mca_btl_ugni_module_t *) btl; btl 79 opal/mca/btl/ugni/btl_ugni_atomic.c int mca_btl_ugni_aop (struct mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint, btl 110 opal/mca/btl/ugni/btl_ugni_atomic.c int mca_btl_ugni_afop (struct mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint, btl 141 opal/mca/btl/ugni/btl_ugni_atomic.c int mca_btl_ugni_acswap (struct mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint, btl 732 opal/mca/btl/ugni/btl_ugni_component.c int mca_btl_ugni_flush (mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint) btl 63 opal/mca/btl/ugni/btl_ugni_endpoint.c mca_btl_ugni_module_t *btl, opal_proc_t *peer_proc) btl 86 opal/mca/btl/ugni/btl_ugni_endpoint.h mca_btl_ugni_module_t *btl, opal_proc_t *peer_proc); btl 22 opal/mca/btl/ugni/btl_ugni_get.c int mca_btl_ugni_get (mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint, void *local_address, btl 48 opal/mca/btl/ugni/btl_ugni_get.c static void mca_btl_ugni_callback_eager_get_progress_pending (struct mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint, btl 51 opal/mca/btl/ugni/btl_ugni_get.c mca_btl_ugni_module_t *ugni_module = (mca_btl_ugni_module_t *) btl; btl 77 opal/mca/btl/ugni/btl_ugni_get.c static void mca_btl_ugni_callback_eager_get (struct mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint, btl 81 opal/mca/btl/ugni/btl_ugni_get.c mca_btl_ugni_module_t *ugni_module = (mca_btl_ugni_module_t *) btl; btl 25 opal/mca/btl/ugni/btl_ugni_module.c mca_btl_ugni_free (struct mca_btl_base_module_t *btl, btl 29 opal/mca/btl/ugni/btl_ugni_module.c mca_btl_ugni_module_finalize (struct mca_btl_base_module_t* btl); btl 32 opal/mca/btl/ugni/btl_ugni_module.c mca_btl_ugni_prepare_src (struct mca_btl_base_module_t *btl, btl 39 opal/mca/btl/ugni/btl_ugni_module.c mca_btl_ugni_register_mem (mca_btl_base_module_t *btl, mca_btl_base_endpoint_t *endpoint, void *base, btl 42 opal/mca/btl/ugni/btl_ugni_module.c static int mca_btl_ugni_deregister_mem (mca_btl_base_module_t *btl, mca_btl_base_registration_handle_t *handle); btl 144 opal/mca/btl/ugni/btl_ugni_module.c mca_btl_ugni_module_finalize (struct mca_btl_base_module_t *btl) btl 146 opal/mca/btl/ugni/btl_ugni_module.c mca_btl_ugni_module_t *ugni_module = (mca_btl_ugni_module_t *)btl; btl 222 opal/mca/btl/ugni/btl_ugni_module.c mca_btl_ugni_alloc(struct mca_btl_base_module_t *btl, btl 237 opal/mca/btl/ugni/btl_ugni_module.c } else if (size <= btl->btl_eager_limit) { btl 276 opal/mca/btl/ugni/btl_ugni_module.c mca_btl_ugni_free (struct mca_btl_base_module_t *btl, btl 283 opal/mca/btl/ugni/btl_ugni_module.c mca_btl_ugni_prepare_src (struct mca_btl_base_module_t *btl, btl 296 opal/mca/btl/ugni/btl_ugni_module.c return mca_btl_ugni_prepare_src_send (btl, endpoint, convertor, btl 301 opal/mca/btl/ugni/btl_ugni_module.c mca_btl_ugni_register_mem (mca_btl_base_module_t *btl, mca_btl_base_endpoint_t *endpoint, void *base, btl 304 opal/mca/btl/ugni/btl_ugni_module.c mca_btl_ugni_module_t *ugni_module = (mca_btl_ugni_module_t *) btl; btl 318 opal/mca/btl/ugni/btl_ugni_module.c static int mca_btl_ugni_deregister_mem (mca_btl_base_module_t *btl, mca_btl_base_registration_handle_t *handle) btl 320 opal/mca/btl/ugni/btl_ugni_module.c mca_btl_ugni_module_t *ugni_module = (mca_btl_ugni_module_t *) btl; btl 22 opal/mca/btl/ugni/btl_ugni_prepare.h mca_btl_ugni_prepare_src_send_nodata (struct mca_btl_base_module_t *btl, btl 53 opal/mca/btl/ugni/btl_ugni_prepare.h mca_btl_ugni_prepare_src_send_inplace (struct mca_btl_base_module_t *btl, btl 60 opal/mca/btl/ugni/btl_ugni_prepare.h mca_btl_ugni_module_t *ugni_module = (mca_btl_ugni_module_t *) btl; btl 111 opal/mca/btl/ugni/btl_ugni_prepare.h mca_btl_ugni_prepare_src_send_buffered (struct mca_btl_base_module_t *btl, btl 172 opal/mca/btl/ugni/btl_ugni_prepare.h mca_btl_ugni_prepare_src_send (struct mca_btl_base_module_t *btl, btl 183 opal/mca/btl/ugni/btl_ugni_prepare.h return mca_btl_ugni_prepare_src_send_nodata (btl, endpoint, order, reserve, flags); btl 188 opal/mca/btl/ugni/btl_ugni_prepare.h send_in_place = (btl->btl_flags & MCA_BTL_FLAGS_SEND_INPLACE) && !(opal_convertor_need_buffers(convertor) || btl 192 opal/mca/btl/ugni/btl_ugni_prepare.h return mca_btl_ugni_prepare_src_send_inplace (btl, endpoint, convertor, order, btl 195 opal/mca/btl/ugni/btl_ugni_prepare.h return mca_btl_ugni_prepare_src_send_buffered (btl, endpoint, convertor, order, btl 34 opal/mca/btl/ugni/btl_ugni_progress_thread.c struct mca_btl_ugni_module_t *btl = (mca_btl_ugni_module_t *)data; btl 41 opal/mca/btl/ugni/btl_ugni_progress_thread.c cq_vec[0] = btl->smsg_remote_irq_cq; btl 43 opal/mca/btl/ugni/btl_ugni_progress_thread.c cq_vec[i + 1] = btl->devices[i].dev_rdma_local_irq_cq.gni_handle; btl 68 opal/mca/btl/ugni/btl_ugni_progress_thread.c int mca_btl_ugni_spawn_progress_thread(struct mca_btl_base_module_t *btl) btl 82 opal/mca/btl/ugni/btl_ugni_progress_thread.c &attr, mca_btl_ugni_prog_thread_fn, (void *)btl); btl 17 opal/mca/btl/ugni/btl_ugni_put.c int mca_btl_ugni_put (mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint, void *local_address, btl 45 opal/mca/btl/ugni/btl_ugni_send.c int mca_btl_ugni_send (struct mca_btl_base_module_t *btl, btl 52 opal/mca/btl/ugni/btl_ugni_send.c mca_btl_ugni_module_t *ugni_module = (mca_btl_ugni_module_t *) btl; btl 109 opal/mca/btl/ugni/btl_ugni_send.c int mca_btl_ugni_sendi (struct mca_btl_base_module_t *btl, btl 137 opal/mca/btl/ugni/btl_ugni_send.c frag = (mca_btl_ugni_base_frag_t *) mca_btl_ugni_prepare_src_send_nodata (btl, endpoint, order, header_size, btl 140 opal/mca/btl/ugni/btl_ugni_send.c frag = (mca_btl_ugni_base_frag_t *) mca_btl_ugni_prepare_src_send_buffered (btl, endpoint, convertor, order, btl 161 opal/mca/btl/ugni/btl_ugni_smsg.c mca_btl_ugni_handle_remote_smsg_overrun (mca_btl_ugni_module_t *btl) btl 174 opal/mca/btl/ugni/btl_ugni_smsg.c mca_btl_ugni_cq_clear (btl->devices, btl->smsg_remote_cq); btl 176 opal/mca/btl/ugni/btl_ugni_smsg.c endpoint_count = opal_pointer_array_get_size (&btl->endpoints); btl 181 opal/mca/btl/ugni/btl_ugni_smsg.c ep = (mca_btl_base_endpoint_t *) opal_pointer_array_get_item (&btl->endpoints, btl 198 opal/mca/btl/ugni/btl_ugni_smsg.c int mca_btl_ugni_progress_remote_smsg (mca_btl_ugni_module_t *btl) btl 205 opal/mca/btl/ugni/btl_ugni_smsg.c grc = mca_btl_ugni_gni_cq_get_event (btl->devices, btl->smsg_remote_cq, &event_data); btl 215 opal/mca/btl/ugni/btl_ugni_smsg.c return mca_btl_ugni_handle_remote_smsg_overrun (btl); btl 232 opal/mca/btl/ugni/btl_ugni_smsg.c ep = (mca_btl_base_endpoint_t *) opal_pointer_array_get_item (&btl->endpoints, inst_id); btl 37 opal/mca/btl/ugni/btl_ugni_smsg.h int mca_btl_ugni_progress_remote_smsg (mca_btl_ugni_module_t *btl); btl 661 opal/mca/btl/usnic/btl_usnic_module.c static int usnic_register_pml_err_cb(struct mca_btl_base_module_t* btl, btl 664 opal/mca/btl/usnic/btl_usnic_module.c opal_btl_usnic_module_t *module = (opal_btl_usnic_module_t*) btl; btl 679 opal/mca/btl/usnic/btl_usnic_module.c usnic_alloc(struct mca_btl_base_module_t* btl, btl 686 opal/mca/btl/usnic/btl_usnic_module.c opal_btl_usnic_module_t *module = (opal_btl_usnic_module_t*) btl; btl 757 opal/mca/btl/usnic/btl_usnic_module.c static int usnic_free(struct mca_btl_base_module_t* btl, btl 771 opal/mca/btl/usnic/btl_usnic_module.c opal_btl_usnic_frag_return_cond((struct opal_btl_usnic_module_t *)btl, btl 868 opal/mca/btl/usnic/btl_usnic_module.c static int usnic_finalize(struct mca_btl_base_module_t* btl) btl 870 opal/mca/btl/usnic/btl_usnic_module.c opal_btl_usnic_module_t* module = (opal_btl_usnic_module_t*)btl; btl 1393 opal/mca/btl/usnic/btl_usnic_module.c static int usnic_sendi(struct mca_btl_base_module_t* btl, btl 193 opal/mca/btl/vader/btl_vader.h int mca_btl_vader_send(struct mca_btl_base_module_t *btl, btl 204 opal/mca/btl/vader/btl_vader.h int mca_btl_vader_sendi (struct mca_btl_base_module_t *btl, btl 220 opal/mca/btl/vader/btl_vader.h int mca_btl_vader_put_xpmem (mca_btl_base_module_t *btl, mca_btl_base_endpoint_t *endpoint, void *local_address, btl 227 opal/mca/btl/vader/btl_vader.h int mca_btl_vader_put_cma (mca_btl_base_module_t *btl, mca_btl_base_endpoint_t *endpoint, void *local_address, btl 234 opal/mca/btl/vader/btl_vader.h int mca_btl_vader_put_knem (mca_btl_base_module_t *btl, mca_btl_base_endpoint_t *endpoint, void *local_address, btl 240 opal/mca/btl/vader/btl_vader.h int mca_btl_vader_put_sc_emu (mca_btl_base_module_t *btl, mca_btl_base_endpoint_t *endpoint, void *local_address, btl 253 opal/mca/btl/vader/btl_vader.h int mca_btl_vader_get_xpmem (mca_btl_base_module_t *btl, mca_btl_base_endpoint_t *endpoint, void *local_address, btl 260 opal/mca/btl/vader/btl_vader.h int mca_btl_vader_get_cma (mca_btl_base_module_t *btl, mca_btl_base_endpoint_t *endpoint, void *local_address, btl 267 opal/mca/btl/vader/btl_vader.h int mca_btl_vader_get_knem (mca_btl_base_module_t *btl, mca_btl_base_endpoint_t *endpoint, void *local_address, btl 273 opal/mca/btl/vader/btl_vader.h int mca_btl_vader_get_sc_emu (mca_btl_base_module_t *btl, mca_btl_base_endpoint_t *endpoint, void *local_address, btl 278 opal/mca/btl/vader/btl_vader.h int mca_btl_vader_emu_aop (struct mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint, btl 283 opal/mca/btl/vader/btl_vader.h int mca_btl_vader_emu_afop (struct mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint, btl 289 opal/mca/btl/vader/btl_vader.h int mca_btl_vader_emu_acswap (struct mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint, btl 302 opal/mca/btl/vader/btl_vader.h mca_btl_base_descriptor_t* mca_btl_vader_alloc (struct mca_btl_base_module_t* btl, btl 312 opal/mca/btl/vader/btl_vader.h int mca_btl_vader_free (struct mca_btl_base_module_t *btl, mca_btl_base_descriptor_t *des); btl 19 opal/mca/btl/vader/btl_vader_atomic.c static void mca_btl_vader_sc_emu_aop_complete (mca_btl_base_module_t *btl, mca_btl_base_endpoint_t *endpoint, btl 31 opal/mca/btl/vader/btl_vader_atomic.c cbfunc (btl, endpoint, local_address, NULL, context, cbdata, status); btl 34 opal/mca/btl/vader/btl_vader_atomic.c int mca_btl_vader_emu_aop (struct mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint, btl 41 opal/mca/btl/vader/btl_vader_atomic.c frag = mca_btl_vader_rdma_frag_alloc (btl, endpoint, MCA_BTL_VADER_OP_ATOMIC, operand, 0, op, 0, order, flags, NULL, btl 48 opal/mca/btl/vader/btl_vader_atomic.c (void) mca_btl_vader_send (btl, endpoint, &frag->base, MCA_BTL_TAG_VADER); btl 53 opal/mca/btl/vader/btl_vader_atomic.c static void mca_btl_vader_sc_emu_afop_complete (mca_btl_base_module_t *btl, mca_btl_base_endpoint_t *endpoint, btl 70 opal/mca/btl/vader/btl_vader_atomic.c cbfunc (btl, endpoint, local_address, NULL, context, cbdata, status); btl 73 opal/mca/btl/vader/btl_vader_atomic.c int mca_btl_vader_emu_afop (struct mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint, btl 81 opal/mca/btl/vader/btl_vader_atomic.c frag = mca_btl_vader_rdma_frag_alloc (btl, endpoint, MCA_BTL_VADER_OP_ATOMIC, operand, 0, op, 0, order, flags, btl 89 opal/mca/btl/vader/btl_vader_atomic.c (void) mca_btl_vader_send (btl, endpoint, &frag->base, MCA_BTL_TAG_VADER); btl 94 opal/mca/btl/vader/btl_vader_atomic.c int mca_btl_vader_emu_acswap (struct mca_btl_base_module_t *btl, struct mca_btl_base_endpoint_t *endpoint, btl 101 opal/mca/btl/vader/btl_vader_atomic.c frag = mca_btl_vader_rdma_frag_alloc (btl, endpoint, MCA_BTL_VADER_OP_CSWAP, compare, value, 0, 0, order, btl 109 opal/mca/btl/vader/btl_vader_atomic.c (void) mca_btl_vader_send (btl, endpoint, &frag->base, MCA_BTL_TAG_VADER); btl 155 opal/mca/btl/vader/btl_vader_frag.h mca_btl_vader_rdma_frag_alloc (mca_btl_base_module_t *btl, mca_btl_base_endpoint_t *endpoint, int type, btl 165 opal/mca/btl/vader/btl_vader_frag.h frag = (mca_btl_vader_frag_t *) mca_btl_vader_alloc (btl, endpoint, order, total_size, btl 39 opal/mca/btl/vader/btl_vader_get.c int mca_btl_vader_get_xpmem (mca_btl_base_module_t *btl, mca_btl_base_endpoint_t *endpoint, void *local_address, btl 61 opal/mca/btl/vader/btl_vader_get.c cbfunc (btl, endpoint, local_address, local_handle, cbcontext, cbdata, OPAL_SUCCESS); btl 68 opal/mca/btl/vader/btl_vader_get.c int mca_btl_vader_get_cma (mca_btl_base_module_t *btl, mca_btl_base_endpoint_t *endpoint, void *local_address, btl 107 opal/mca/btl/vader/btl_vader_get.c cbfunc (btl, endpoint, local_address, local_handle, cbcontext, cbdata, OPAL_SUCCESS); btl 114 opal/mca/btl/vader/btl_vader_get.c int mca_btl_vader_get_knem (mca_btl_base_module_t *btl, mca_btl_base_endpoint_t *endpoint, void *local_address, btl 153 opal/mca/btl/vader/btl_vader_get.c cbfunc (btl, endpoint, local_address, local_handle, cbcontext, cbdata, OPAL_SUCCESS); btl 159 opal/mca/btl/vader/btl_vader_get.c static void mca_btl_vader_sc_emu_get_complete (mca_btl_base_module_t *btl, mca_btl_base_endpoint_t *endpoint, btl 179 opal/mca/btl/vader/btl_vader_get.c cbfunc (btl, endpoint, local_address, NULL, context, cbdata, status); btl 182 opal/mca/btl/vader/btl_vader_get.c int mca_btl_vader_get_sc_emu (mca_btl_base_module_t *btl, mca_btl_base_endpoint_t *endpoint, void *local_address, btl 193 opal/mca/btl/vader/btl_vader_get.c frag = mca_btl_vader_rdma_frag_alloc (btl, endpoint, MCA_BTL_VADER_OP_GET, 0, 0, 0, order, flags, size, btl 201 opal/mca/btl/vader/btl_vader_get.c (void) mca_btl_vader_send (btl, endpoint, &frag->base, MCA_BTL_TAG_VADER); btl 70 opal/mca/btl/vader/btl_vader_knem.c mca_btl_vader_register_mem_knem (struct mca_btl_base_module_t* btl, btl 74 opal/mca/btl/vader/btl_vader_knem.c mca_btl_vader_t *vader_module = (mca_btl_vader_t *) btl; btl 90 opal/mca/btl/vader/btl_vader_knem.c mca_btl_vader_deregister_mem_knem (struct mca_btl_base_module_t *btl, struct mca_btl_base_registration_handle_t *handle) btl 92 opal/mca/btl/vader/btl_vader_knem.c mca_btl_vader_t *vader_module = (mca_btl_vader_t *) btl; btl 39 opal/mca/btl/vader/btl_vader_module.c static int vader_del_procs (struct mca_btl_base_module_t *btl, btl 43 opal/mca/btl/vader/btl_vader_module.c static int vader_register_error_cb (struct mca_btl_base_module_t* btl, btl 46 opal/mca/btl/vader/btl_vader_module.c static int vader_finalize (struct mca_btl_base_module_t* btl); btl 49 opal/mca/btl/vader/btl_vader_module.c struct mca_btl_base_module_t *btl, btl 58 opal/mca/btl/vader/btl_vader_module.c static int vader_add_procs(struct mca_btl_base_module_t* btl, btl 251 opal/mca/btl/vader/btl_vader_module.c static int vader_add_procs (struct mca_btl_base_module_t* btl, btl 257 opal/mca/btl/vader/btl_vader_module.c mca_btl_vader_t *vader_btl = (mca_btl_vader_t *) btl; btl 323 opal/mca/btl/vader/btl_vader_module.c static int vader_del_procs(struct mca_btl_base_module_t *btl, btl 351 opal/mca/btl/vader/btl_vader_module.c static int vader_finalize(struct mca_btl_base_module_t *btl) btl 354 opal/mca/btl/vader/btl_vader_module.c mca_btl_vader_t *vader_btl = (mca_btl_vader_t *) btl; btl 394 opal/mca/btl/vader/btl_vader_module.c static int vader_register_error_cb(struct mca_btl_base_module_t* btl, btl 397 opal/mca/btl/vader/btl_vader_module.c ((mca_btl_vader_t *)btl)->error_cb = cbfunc; btl 407 opal/mca/btl/vader/btl_vader_module.c mca_btl_base_descriptor_t *mca_btl_vader_alloc(struct mca_btl_base_module_t *btl, btl 438 opal/mca/btl/vader/btl_vader_module.c int mca_btl_vader_free (struct mca_btl_base_module_t *btl, mca_btl_base_descriptor_t *des) btl 450 opal/mca/btl/vader/btl_vader_module.c static struct mca_btl_base_descriptor_t *vader_prepare_src (struct mca_btl_base_module_t *btl, btl 38 opal/mca/btl/vader/btl_vader_put.c int mca_btl_vader_put_xpmem (mca_btl_base_module_t *btl, mca_btl_base_endpoint_t *endpoint, void *local_address, btl 56 opal/mca/btl/vader/btl_vader_put.c cbfunc (btl, endpoint, local_address, local_handle, cbcontext, cbdata, OPAL_SUCCESS); btl 63 opal/mca/btl/vader/btl_vader_put.c int mca_btl_vader_put_cma (mca_btl_base_module_t *btl, mca_btl_base_endpoint_t *endpoint, void *local_address, btl 86 opal/mca/btl/vader/btl_vader_put.c cbfunc (btl, endpoint, local_address, local_handle, cbcontext, cbdata, OPAL_SUCCESS); btl 93 opal/mca/btl/vader/btl_vader_put.c int mca_btl_vader_put_knem (mca_btl_base_module_t *btl, mca_btl_base_endpoint_t *endpoint, void *local_address, btl 132 opal/mca/btl/vader/btl_vader_put.c cbfunc (btl, endpoint, local_address, local_handle, cbcontext, cbdata, OPAL_SUCCESS); btl 138 opal/mca/btl/vader/btl_vader_put.c static void mca_btl_vader_sc_emu_put_complete (mca_btl_base_module_t *btl, mca_btl_base_endpoint_t *endpoint, btl 150 opal/mca/btl/vader/btl_vader_put.c cbfunc (btl, endpoint, local_address, NULL, context, cbdata, status); btl 156 opal/mca/btl/vader/btl_vader_put.c int mca_btl_vader_put_sc_emu (mca_btl_base_module_t *btl, mca_btl_base_endpoint_t *endpoint, void *local_address, btl 168 opal/mca/btl/vader/btl_vader_put.c frag = mca_btl_vader_rdma_frag_alloc (btl, endpoint, MCA_BTL_VADER_OP_PUT, 0, 0, 0, order, flags, size, btl 180 opal/mca/btl/vader/btl_vader_put.c (void) mca_btl_vader_send (btl, endpoint, &frag->base, MCA_BTL_TAG_VADER); btl 93 opal/mca/btl/vader/btl_vader_sc_emu.c static void mca_btl_vader_sc_emu_rdma (mca_btl_base_module_t *btl, mca_btl_base_tag_t tag, mca_btl_base_descriptor_t *desc, void *ctx) btl 37 opal/mca/btl/vader/btl_vader_send.c int mca_btl_vader_send (struct mca_btl_base_module_t *btl, btl 40 opal/mca/btl/vader/btl_vader_sendi.c int mca_btl_vader_sendi (struct mca_btl_base_module_t *btl, btl 73 opal/mca/btl/vader/btl_vader_sendi.c frag = (mca_btl_vader_frag_t *) mca_btl_vader_alloc (btl, endpoint, order, length, btl 111 opal/mca/btl/vader/btl_vader_sendi.c mca_btl_vader_free (btl, &frag->base);