bml_endpoint 149 ompi/mca/bml/r2/bml_r2.c mca_bml_base_endpoint_t *bml_endpoint; bml_endpoint 152 ompi/mca/bml/r2/bml_r2.c bml_endpoint = OBJ_NEW(mca_bml_base_endpoint_t); bml_endpoint 153 ompi/mca/bml/r2/bml_r2.c if (NULL == bml_endpoint) { bml_endpoint 159 ompi/mca/bml/r2/bml_r2.c mca_bml_base_btl_array_reserve(&bml_endpoint->btl_eager, mca_bml_r2.num_btl_modules); bml_endpoint 160 ompi/mca/bml/r2/bml_r2.c mca_bml_base_btl_array_reserve(&bml_endpoint->btl_send, mca_bml_r2.num_btl_modules); bml_endpoint 161 ompi/mca/bml/r2/bml_r2.c mca_bml_base_btl_array_reserve(&bml_endpoint->btl_rdma, mca_bml_r2.num_btl_modules); bml_endpoint 162 ompi/mca/bml/r2/bml_r2.c bml_endpoint->btl_max_send_size = -1; bml_endpoint 163 ompi/mca/bml/r2/bml_r2.c bml_endpoint->btl_proc = proc; bml_endpoint 165 ompi/mca/bml/r2/bml_r2.c bml_endpoint->btl_flags_or = 0; bml_endpoint 166 ompi/mca/bml/r2/bml_r2.c return bml_endpoint; bml_endpoint 197 ompi/mca/bml/r2/bml_r2.c static int mca_bml_r2_endpoint_add_btl (struct ompi_proc_t *proc, mca_bml_base_endpoint_t *bml_endpoint, bml_endpoint 231 ompi/mca/bml/r2/bml_r2.c size = mca_bml_base_btl_array_get_size (&bml_endpoint->btl_send); bml_endpoint 232 ompi/mca/bml/r2/bml_r2.c bml_btl = mca_bml_base_btl_array_get_index (&bml_endpoint->btl_send, size - 1); bml_endpoint 245 ompi/mca/bml/r2/bml_r2.c bml_btl = mca_bml_base_btl_array_insert (&bml_endpoint->btl_send); bml_endpoint 254 ompi/mca/bml/r2/bml_r2.c bml_endpoint->btl_flags_or |= bml_btl->btl_flags; bml_endpoint 275 ompi/mca/bml/r2/bml_r2.c mca_bml_base_btl_t *bml_btl_rdma = mca_bml_base_btl_array_insert(&bml_endpoint->btl_rdma); bml_endpoint 282 ompi/mca/bml/r2/bml_r2.c if (bml_endpoint->btl_pipeline_send_length < btl->btl_rdma_pipeline_send_length) { bml_endpoint 283 ompi/mca/bml/r2/bml_r2.c bml_endpoint->btl_pipeline_send_length = btl->btl_rdma_pipeline_send_length; bml_endpoint 286 ompi/mca/bml/r2/bml_r2.c if (bml_endpoint->btl_send_limit < btl->btl_min_rdma_pipeline_size) { bml_endpoint 287 ompi/mca/bml/r2/bml_r2.c bml_endpoint->btl_send_limit = btl->btl_min_rdma_pipeline_size; bml_endpoint 296 ompi/mca/bml/r2/bml_r2.c static void mca_bml_r2_compute_endpoint_metrics (mca_bml_base_endpoint_t *bml_endpoint) bml_endpoint 309 ompi/mca/bml/r2/bml_r2.c n_send = mca_bml_base_btl_array_get_size (&bml_endpoint->btl_send); bml_endpoint 310 ompi/mca/bml/r2/bml_r2.c n_rdma = mca_bml_base_btl_array_get_size (&bml_endpoint->btl_rdma); bml_endpoint 313 ompi/mca/bml/r2/bml_r2.c qsort (bml_endpoint->btl_send.bml_btls, n_send, bml_endpoint 316 ompi/mca/bml/r2/bml_r2.c bml_endpoint->btl_rdma_index = 0; bml_endpoint 318 ompi/mca/bml/r2/bml_r2.c mca_bml_r2_calculate_bandwidth_latency (&bml_endpoint->btl_send, &total_bandwidth, &latency); bml_endpoint 326 ompi/mca/bml/r2/bml_r2.c mca_bml_base_btl_array_get_index(&bml_endpoint->btl_send, n_index); bml_endpoint 341 ompi/mca/bml/r2/bml_r2.c mca_bml_base_btl_array_insert(&bml_endpoint->btl_eager); bml_endpoint 346 ompi/mca/bml/r2/bml_r2.c if (bml_endpoint->btl_max_send_size > btl->btl_max_send_size) bml_endpoint 347 ompi/mca/bml/r2/bml_r2.c bml_endpoint->btl_max_send_size = btl->btl_max_send_size; bml_endpoint 351 ompi/mca/bml/r2/bml_r2.c qsort(bml_endpoint->btl_rdma.bml_btls, n_rdma, bml_endpoint 354 ompi/mca/bml/r2/bml_r2.c mca_bml_r2_calculate_bandwidth_latency (&bml_endpoint->btl_rdma, &total_bandwidth, &latency); bml_endpoint 359 ompi/mca/bml/r2/bml_r2.c mca_bml_base_btl_array_get_index(&bml_endpoint->btl_rdma, n_index); bml_endpoint 372 ompi/mca/bml/r2/bml_r2.c mca_bml_base_endpoint_t *bml_endpoint; bml_endpoint 392 ompi/mca/bml/r2/bml_r2.c bml_endpoint = mca_bml_r2_allocate_endpoint (proc); bml_endpoint 393 ompi/mca/bml/r2/bml_r2.c if (OPAL_UNLIKELY(NULL == bml_endpoint)) { bml_endpoint 413 ompi/mca/bml/r2/bml_r2.c rc = mca_bml_r2_endpoint_add_btl (proc, bml_endpoint, btl, btl_endpoint); bml_endpoint 424 ompi/mca/bml/r2/bml_r2.c OBJ_RELEASE(bml_endpoint); bml_endpoint 441 ompi/mca/bml/r2/bml_r2.c mca_bml_r2_compute_endpoint_metrics (bml_endpoint); bml_endpoint 445 ompi/mca/bml/r2/bml_r2.c proc->proc_endpoints[OMPI_PROC_ENDPOINT_TAG_BML] = bml_endpoint; bml_endpoint 535 ompi/mca/bml/r2/bml_r2.c mca_bml_base_endpoint_t *bml_endpoint = bml_endpoint 538 ompi/mca/bml/r2/bml_r2.c if (NULL == bml_endpoint) { bml_endpoint 539 ompi/mca/bml/r2/bml_r2.c bml_endpoint = mca_bml_r2_allocate_endpoint (proc); bml_endpoint 540 ompi/mca/bml/r2/bml_r2.c proc->proc_endpoints[OMPI_PROC_ENDPOINT_TAG_BML] = bml_endpoint; bml_endpoint 541 ompi/mca/bml/r2/bml_r2.c if (NULL == bml_endpoint) { bml_endpoint 548 ompi/mca/bml/r2/bml_r2.c rc = mca_bml_r2_endpoint_add_btl (proc, bml_endpoint, btl, btl_endpoints[p]); bml_endpoint 565 ompi/mca/bml/r2/bml_r2.c mca_bml_base_endpoint_t *bml_endpoint = bml_endpoint 569 ompi/mca/bml/r2/bml_r2.c if (NULL != bml_endpoint) { bml_endpoint 570 ompi/mca/bml/r2/bml_r2.c mca_bml_r2_compute_endpoint_metrics (bml_endpoint); bml_endpoint 610 ompi/mca/bml/r2/bml_r2.c mca_bml_base_endpoint_t *bml_endpoint = bml_endpoint 613 ompi/mca/bml/r2/bml_r2.c if (!bml_endpoint) { bml_endpoint 619 ompi/mca/bml/r2/bml_r2.c size_t f_size = mca_bml_base_btl_array_get_size (&bml_endpoint->btl_send); bml_endpoint 621 ompi/mca/bml/r2/bml_r2.c mca_bml_base_btl_t* bml_btl = mca_bml_base_btl_array_get_index(&bml_endpoint->btl_send, f_index); bml_endpoint 636 ompi/mca/bml/r2/bml_r2.c size_t r_size = mca_bml_base_btl_array_get_size (&bml_endpoint->btl_rdma); bml_endpoint 638 ompi/mca/bml/r2/bml_r2.c mca_bml_base_btl_t *rdma_btl = mca_bml_base_btl_array_get_index (&bml_endpoint->btl_rdma, r_index); bml_endpoint 643 ompi/mca/bml/r2/bml_r2.c mca_bml_base_btl_t *bml_btl = mca_bml_base_btl_array_get_index (&bml_endpoint->btl_send, f_index); bml_endpoint 664 ompi/mca/bml/r2/bml_r2.c OBJ_RELEASE(bml_endpoint); bml_endpoint 39 ompi/mca/osc/rdma/osc_rdma_peer.c mca_bml_base_endpoint_t *bml_endpoint; bml_endpoint 43 ompi/mca/osc/rdma/osc_rdma_peer.c bml_endpoint = mca_bml_base_get_endpoint (proc); bml_endpoint 45 ompi/mca/osc/rdma/osc_rdma_peer.c num_btls = mca_bml_base_btl_array_get_size (&bml_endpoint->btl_rdma); bml_endpoint 48 ompi/mca/osc/rdma/osc_rdma_peer.c if (bml_endpoint->btl_rdma.bml_btls[btl_index].btl == module->selected_btl) { bml_endpoint 49 ompi/mca/osc/rdma/osc_rdma_peer.c return bml_endpoint->btl_rdma.bml_btls[btl_index].btl_endpoint; bml_endpoint 42 ompi/mca/pml/ob1/pml_ob1_cuda.c mca_bml_base_endpoint_t* bml_endpoint, bml_endpoint 104 ompi/mca/pml/ob1/pml_ob1_cuda.c mca_bml_base_endpoint_t* bml_endpoint, bml_endpoint 109 ompi/mca/pml/ob1/pml_ob1_cuda.c int num_btls = mca_bml_base_btl_array_get_size(&bml_endpoint->btl_send); bml_endpoint 122 ompi/mca/pml/ob1/pml_ob1_cuda.c mca_bml_base_btl_array_get_index(&bml_endpoint->btl_send, n); bml_endpoint 160 ompi/mca/pml/ob1/pml_ob1_cuda.c mca_bml_base_endpoint_t* bml_endpoint = mca_bml_base_get_endpoint (recvreq->req_recv.req_base.req_proc); bml_endpoint 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); bml_endpoint 165 ompi/mca/pml/ob1/pml_ob1_cuda.c bml_btl = mca_bml_base_btl_array_find(&bml_endpoint->btl_rdma, btl); bml_endpoint 40 ompi/mca/pml/ob1/pml_ob1_rdma.c mca_bml_base_endpoint_t* bml_endpoint, bml_endpoint 45 ompi/mca/pml/ob1/pml_ob1_rdma.c int num_btls = mca_bml_base_btl_array_get_size(&bml_endpoint->btl_rdma); bml_endpoint 46 ompi/mca/pml/ob1/pml_ob1_rdma.c int num_eager_btls = mca_bml_base_btl_array_get_size (&bml_endpoint->btl_eager); bml_endpoint 58 ompi/mca/pml/ob1/pml_ob1_rdma.c mca_bml_base_btl_array_get_index(&bml_endpoint->btl_rdma, bml_endpoint 59 ompi/mca/pml/ob1/pml_ob1_rdma.c (bml_endpoint->btl_rdma_index + n) % num_btls); bml_endpoint 68 ompi/mca/pml/ob1/pml_ob1_rdma.c mca_bml_base_btl_t *eager_btl = mca_bml_base_btl_array_get_index (&bml_endpoint->btl_eager, i); bml_endpoint 112 ompi/mca/pml/ob1/pml_ob1_rdma.c bml_endpoint->btl_rdma_index = (bml_endpoint->btl_rdma_index + 1) % num_btls; bml_endpoint 116 ompi/mca/pml/ob1/pml_ob1_rdma.c size_t mca_pml_ob1_rdma_pipeline_btls_count (mca_bml_base_endpoint_t* bml_endpoint) bml_endpoint 118 ompi/mca/pml/ob1/pml_ob1_rdma.c int num_btls = mca_bml_base_btl_array_get_size (&bml_endpoint->btl_rdma); bml_endpoint 119 ompi/mca/pml/ob1/pml_ob1_rdma.c int num_eager_btls = mca_bml_base_btl_array_get_size (&bml_endpoint->btl_eager); bml_endpoint 123 ompi/mca/pml/ob1/pml_ob1_rdma.c mca_bml_base_btl_t *bml_btl = mca_bml_base_btl_array_get_next(&bml_endpoint->btl_rdma); bml_endpoint 128 ompi/mca/pml/ob1/pml_ob1_rdma.c mca_bml_base_btl_t *eager_btl = mca_bml_base_btl_array_get_index (&bml_endpoint->btl_eager, i); bml_endpoint 143 ompi/mca/pml/ob1/pml_ob1_rdma.c size_t mca_pml_ob1_rdma_pipeline_btls( mca_bml_base_endpoint_t* bml_endpoint, bml_endpoint 147 ompi/mca/pml/ob1/pml_ob1_rdma.c int num_btls = mca_bml_base_btl_array_get_size (&bml_endpoint->btl_rdma); bml_endpoint 148 ompi/mca/pml/ob1/pml_ob1_rdma.c int num_eager_btls = mca_bml_base_btl_array_get_size (&bml_endpoint->btl_eager); bml_endpoint 153 ompi/mca/pml/ob1/pml_ob1_rdma.c mca_bml_base_btl_t *bml_btl = mca_bml_base_btl_array_get_next(&bml_endpoint->btl_rdma); bml_endpoint 158 ompi/mca/pml/ob1/pml_ob1_rdma.c mca_bml_base_btl_t *eager_btl = mca_bml_base_btl_array_get_index (&bml_endpoint->btl_eager, i); bml_endpoint 44 ompi/mca/pml/ob1/pml_ob1_rdma.h size_t mca_pml_ob1_rdma_pipeline_btls_count (mca_bml_base_endpoint_t* bml_endpoint); bml_endpoint 268 ompi/mca/pml/ob1/pml_ob1_recvreq.c mca_bml_base_endpoint_t* bml_endpoint = NULL; bml_endpoint 270 ompi/mca/pml/ob1/pml_ob1_recvreq.c bml_endpoint = mca_bml_base_get_endpoint (proc); bml_endpoint 275 ompi/mca/pml/ob1/pml_ob1_recvreq.c size_t rdma_num = mca_pml_ob1_rdma_pipeline_btls_count (bml_endpoint); bml_endpoint 288 ompi/mca/pml/ob1/pml_ob1_recvreq.c recvreq->req_rdma_cnt = mca_pml_ob1_rdma_btls(bml_endpoint, bml_endpoint 298 ompi/mca/pml/ob1/pml_ob1_recvreq.c } else if(bml_endpoint->btl_send_limit < hdr->hdr_msg_length) { bml_endpoint 301 ompi/mca/pml/ob1/pml_ob1_recvreq.c bml_endpoint->btl_pipeline_send_length; bml_endpoint 312 ompi/mca/pml/ob1/pml_ob1_recvreq.c mca_pml_ob1_rdma_pipeline_btls(bml_endpoint, bml_endpoint 659 ompi/mca/pml/ob1/pml_ob1_recvreq.c mca_bml_base_endpoint_t* bml_endpoint = NULL; bml_endpoint 687 ompi/mca/pml/ob1/pml_ob1_recvreq.c bml_endpoint = mca_bml_base_get_endpoint (recvreq->req_recv.req_base.req_proc); bml_endpoint 688 ompi/mca/pml/ob1/pml_ob1_recvreq.c rdma_bml = mca_bml_base_btl_array_find(&bml_endpoint->btl_rdma, btl); bml_endpoint 694 ompi/mca/pml/ob1/pml_ob1_recvreq.c bml_btl = mca_bml_base_btl_array_find(&bml_endpoint->btl_send, btl); bml_endpoint 851 ompi/mca/pml/ob1/pml_ob1_sendreq.c mca_bml_base_endpoint_t* bml_endpoint = sendreq->req_endpoint; bml_endpoint 852 ompi/mca/pml/ob1/pml_ob1_sendreq.c int num_btls = mca_bml_base_btl_array_get_size(&bml_endpoint->btl_send); bml_endpoint 869 ompi/mca/pml/ob1/pml_ob1_sendreq.c mca_bml_base_btl_array_get_next(&bml_endpoint->btl_send); bml_endpoint 1224 ompi/mca/pml/ob1/pml_ob1_sendreq.c mca_bml_base_endpoint_t *bml_endpoint = sendreq->req_endpoint; bml_endpoint 1251 ompi/mca/pml/ob1/pml_ob1_sendreq.c frag->rdma_bml = mca_bml_base_btl_array_find(&bml_endpoint->btl_rdma, btl);