gather 167 ompi/mca/coll/base/coll_base_comm_select.c COPY(avail->ac_module, comm, gather); gather 252 ompi/mca/coll/base/coll_base_comm_select.c CHECK_NULL(which_func, comm, gather) || gather 62 ompi/mca/coll/base/coll_base_comm_unselect.c CLOSE(comm, gather); gather 130 ompi/mca/coll/demo/coll_demo_component.c RELEASE(module, gather); gather 196 ompi/mca/coll/demo/coll_demo_module.c COPY(comm, demo_module, gather); gather 74 ompi/mca/coll/monitoring/coll_monitoring_component.c operation(m, c, gather); \ gather 184 ompi/mca/coll/portals4/coll_portals4_gather.c int vrank = VRANK(request->u.gather.my_rank, request->u.gather.root_rank, request->u.gather.size); gather 186 ompi/mca/coll/portals4/coll_portals4_gather.c ompi_coll_portals4_create_send_converter (&request->u.gather.send_converter, gather 187 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.pack_src_buf + request->u.gather.pack_src_offset, gather 188 ompi/mca/coll/portals4/coll_portals4_gather.c ompi_comm_peer_lookup(comm, request->u.gather.my_rank), gather 189 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.pack_src_count, gather 190 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.pack_src_dtype); gather 191 ompi/mca/coll/portals4/coll_portals4_gather.c opal_convertor_get_packed_size(&request->u.gather.send_converter, &request->u.gather.packed_size); gather 197 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.gather_bytes=request->u.gather.packed_size * (ptrdiff_t)request->u.gather.size; gather 204 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.gather_buf = (char *) malloc(request->u.gather.gather_bytes); gather 205 ompi/mca/coll/portals4/coll_portals4_gather.c if (NULL == request->u.gather.gather_buf) { gather 208 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.free_after = 1; gather 211 ompi/mca/coll/portals4/coll_portals4_gather.c iov.iov_len = request->u.gather.gather_bytes; gather 212 ompi/mca/coll/portals4/coll_portals4_gather.c iov.iov_base = (IOVBASE_TYPE *) request->u.gather.gather_buf; gather 213 ompi/mca/coll/portals4/coll_portals4_gather.c opal_convertor_pack(&request->u.gather.send_converter, &iov, &iov_count, &max_data); gather 218 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.gather_buf, request->u.gather.gather_bytes, gather 219 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.packed_size, request->u.gather.size); gather 226 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.gather_bytes=request->u.gather.packed_size * ((ptrdiff_t)bmtree->tree_numdescendants + 1); gather 228 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.gather_buf = (char *) malloc(request->u.gather.gather_bytes); gather 229 ompi/mca/coll/portals4/coll_portals4_gather.c if (NULL == request->u.gather.gather_buf) { gather 232 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.free_after = 1; gather 234 ompi/mca/coll/portals4/coll_portals4_gather.c iov.iov_len = request->u.gather.gather_bytes; gather 235 ompi/mca/coll/portals4/coll_portals4_gather.c iov.iov_base = (IOVBASE_TYPE *) request->u.gather.gather_buf; gather 236 ompi/mca/coll/portals4/coll_portals4_gather.c opal_convertor_pack(&request->u.gather.send_converter, &iov, &iov_count, &max_data); gather 241 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.gather_buf, request->u.gather.gather_bytes, gather 242 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.packed_size, bmtree->tree_numdescendants); gather 245 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.gather_bytes=request->u.gather.packed_size; gather 247 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.gather_buf = (char *) malloc(request->u.gather.gather_bytes); gather 248 ompi/mca/coll/portals4/coll_portals4_gather.c if (NULL == request->u.gather.gather_buf) { gather 251 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.free_after = 1; gather 253 ompi/mca/coll/portals4/coll_portals4_gather.c iov.iov_len = request->u.gather.gather_bytes; gather 254 ompi/mca/coll/portals4/coll_portals4_gather.c iov.iov_base = (IOVBASE_TYPE *) request->u.gather.gather_buf; gather 255 ompi/mca/coll/portals4/coll_portals4_gather.c opal_convertor_pack(&request->u.gather.send_converter, &iov, &iov_count, &max_data); gather 260 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.gather_buf, request->u.gather.gather_bytes, gather 261 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.packed_size); gather 269 ompi/mca/coll/portals4/coll_portals4_gather.c __FILE__, __LINE__, line, ret, request->u.gather.my_rank); gather 285 ompi/mca/coll/portals4/coll_portals4_gather.c int8_t i_am_root = (request->u.gather.my_rank == request->u.gather.root_rank); gather 287 ompi/mca/coll/portals4/coll_portals4_gather.c ompi_coll_portals4_create_send_converter (&request->u.gather.send_converter, gather 288 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.pack_src_buf + request->u.gather.pack_src_offset, gather 289 ompi/mca/coll/portals4/coll_portals4_gather.c ompi_comm_peer_lookup(comm, request->u.gather.my_rank), gather 290 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.pack_src_count, gather 291 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.pack_src_dtype); gather 292 ompi/mca/coll/portals4/coll_portals4_gather.c opal_convertor_get_packed_size(&request->u.gather.send_converter, &request->u.gather.packed_size); gather 298 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.gather_bytes=request->u.gather.packed_size * (ptrdiff_t)request->u.gather.size; gather 304 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.gather_buf = (char *) malloc(request->u.gather.gather_bytes); gather 305 ompi/mca/coll/portals4/coll_portals4_gather.c if (NULL == request->u.gather.gather_buf) { gather 308 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.free_after = 1; gather 311 ompi/mca/coll/portals4/coll_portals4_gather.c uint64_t gather_buf_offset = (ptrdiff_t)request->u.gather.my_rank * request->u.gather.packed_size; gather 312 ompi/mca/coll/portals4/coll_portals4_gather.c iov.iov_len = request->u.gather.gather_bytes - gather_buf_offset; gather 313 ompi/mca/coll/portals4/coll_portals4_gather.c iov.iov_base = (IOVBASE_TYPE *) (request->u.gather.gather_buf + gather_buf_offset); gather 314 ompi/mca/coll/portals4/coll_portals4_gather.c opal_convertor_pack(&request->u.gather.send_converter, &iov, &iov_count, &max_data); gather 318 ompi/mca/coll/portals4/coll_portals4_gather.c __FILE__, __LINE__, request->u.gather.my_rank, gather 319 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.gather_buf, request->u.gather.gather_bytes, gather 320 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.packed_size, request->u.gather.size); gather 323 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.gather_bytes=request->u.gather.packed_size; gather 324 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.gather_buf = (char *) malloc(request->u.gather.gather_bytes); gather 325 ompi/mca/coll/portals4/coll_portals4_gather.c if (NULL == request->u.gather.gather_buf) { gather 328 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.free_after = 1; gather 330 ompi/mca/coll/portals4/coll_portals4_gather.c iov.iov_len = request->u.gather.gather_bytes; gather 331 ompi/mca/coll/portals4/coll_portals4_gather.c iov.iov_base = (IOVBASE_TYPE *) request->u.gather.gather_buf; gather 332 ompi/mca/coll/portals4/coll_portals4_gather.c opal_convertor_pack(&request->u.gather.send_converter, &iov, &iov_count, &max_data); gather 336 ompi/mca/coll/portals4/coll_portals4_gather.c __FILE__, __LINE__, request->u.gather.my_rank, gather 337 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.gather_buf, request->u.gather.gather_bytes, gather 338 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.packed_size); gather 346 ompi/mca/coll/portals4/coll_portals4_gather.c __FILE__, __LINE__, line, ret, request->u.gather.my_rank); gather 363 ompi/mca/coll/portals4/coll_portals4_gather.c COLL_PORTALS4_SET_BITS(request->u.gather.gather_match_bits, ompi_comm_get_cid(comm), gather 364 ompi/mca/coll/portals4/coll_portals4_gather.c 0, 0, COLL_PORTALS4_GATHER, 0, request->u.gather.coll_count); gather 367 ompi/mca/coll/portals4/coll_portals4_gather.c &request->u.gather.gather_cth); gather 370 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.gather_mdh = mca_coll_portals4_component.data_md_h; gather 371 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.gather_offset = (ptl_size_t)request->u.gather.gather_buf; gather 374 ompi/mca/coll/portals4/coll_portals4_gather.c me.start = request->u.gather.gather_buf; gather 375 ompi/mca/coll/portals4/coll_portals4_gather.c me.length = request->u.gather.gather_bytes; gather 376 ompi/mca/coll/portals4/coll_portals4_gather.c me.ct_handle = request->u.gather.gather_cth; gather 384 ompi/mca/coll/portals4/coll_portals4_gather.c me.match_bits = request->u.gather.gather_match_bits; gather 391 ompi/mca/coll/portals4/coll_portals4_gather.c &request->u.gather.gather_meh); gather 399 ompi/mca/coll/portals4/coll_portals4_gather.c __FILE__, __LINE__, line, ret, request->u.gather.my_rank); gather 416 ompi/mca/coll/portals4/coll_portals4_gather.c COLL_PORTALS4_SET_BITS(request->u.gather.sync_match_bits, ompi_comm_get_cid(comm), gather 417 ompi/mca/coll/portals4/coll_portals4_gather.c 0, 1, COLL_PORTALS4_GATHER, 0, request->u.gather.coll_count); gather 420 ompi/mca/coll/portals4/coll_portals4_gather.c &request->u.gather.sync_cth); gather 423 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.sync_mdh = mca_coll_portals4_component.zero_md_h; gather 427 ompi/mca/coll/portals4/coll_portals4_gather.c me.ct_handle = request->u.gather.sync_cth; gather 435 ompi/mca/coll/portals4/coll_portals4_gather.c me.match_bits = request->u.gather.sync_match_bits; gather 442 ompi/mca/coll/portals4/coll_portals4_gather.c &request->u.gather.sync_meh); gather 450 ompi/mca/coll/portals4/coll_portals4_gather.c __FILE__, __LINE__, line, ret, request->u.gather.my_rank); gather 464 ompi/mca/coll/portals4/coll_portals4_gather.c ret = PtlMEUnlink(request->u.gather.gather_meh); gather 468 ompi/mca/coll/portals4/coll_portals4_gather.c ret = PtlCTFree(request->u.gather.gather_cth); gather 476 ompi/mca/coll/portals4/coll_portals4_gather.c __FILE__, __LINE__, line, ret, request->u.gather.my_rank); gather 490 ompi/mca/coll/portals4/coll_portals4_gather.c ret = PtlMEUnlink(request->u.gather.sync_meh); gather 494 ompi/mca/coll/portals4/coll_portals4_gather.c ret = PtlCTFree(request->u.gather.sync_cth); gather 502 ompi/mca/coll/portals4/coll_portals4_gather.c __FILE__, __LINE__, line, ret, request->u.gather.my_rank); gather 534 ompi/mca/coll/portals4/coll_portals4_gather.c "coll:portals4:gather_intra_binomial_top enter rank %d", request->u.gather.my_rank)); gather 537 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.gather_buf=NULL; gather 538 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.gather_mdh=PTL_INVALID_HANDLE; gather 539 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.gather_cth=PTL_INVALID_HANDLE; gather 540 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.gather_meh=PTL_INVALID_HANDLE; gather 541 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.sync_mdh=PTL_INVALID_HANDLE; gather 542 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.sync_cth=PTL_INVALID_HANDLE; gather 543 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.sync_meh=PTL_INVALID_HANDLE; gather 545 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.my_rank = ompi_comm_rank(comm); gather 546 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.size = ompi_comm_size(comm); gather 547 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.root_rank = root; gather 548 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.sbuf = sbuf; gather 549 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.rbuf = rbuf; gather 550 ompi/mca/coll/portals4/coll_portals4_gather.c if ((root == request->u.gather.my_rank) && (sbuf == MPI_IN_PLACE)) { gather 551 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.pack_src_buf = rbuf; gather 552 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.pack_src_count = rcount; gather 553 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.pack_src_dtype = rdtype; gather 555 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.pack_src_buf = sbuf; gather 556 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.pack_src_count = scount; gather 557 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.pack_src_dtype = sdtype; gather 558 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.pack_src_offset = 0; gather 560 ompi/mca/coll/portals4/coll_portals4_gather.c ompi_datatype_get_extent(request->u.gather.pack_src_dtype, gather 561 ompi/mca/coll/portals4/coll_portals4_gather.c &request->u.gather.pack_src_lb, gather 562 ompi/mca/coll/portals4/coll_portals4_gather.c &request->u.gather.pack_src_extent); gather 563 ompi/mca/coll/portals4/coll_portals4_gather.c ompi_datatype_get_true_extent(request->u.gather.pack_src_dtype, gather 564 ompi/mca/coll/portals4/coll_portals4_gather.c &request->u.gather.pack_src_true_lb, gather 565 ompi/mca/coll/portals4/coll_portals4_gather.c &request->u.gather.pack_src_true_extent); gather 566 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.unpack_dst_buf = rbuf; gather 567 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.unpack_dst_count = rcount; gather 568 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.unpack_dst_dtype = rdtype; gather 569 ompi/mca/coll/portals4/coll_portals4_gather.c ompi_datatype_get_extent(request->u.gather.unpack_dst_dtype, gather 570 ompi/mca/coll/portals4/coll_portals4_gather.c &request->u.gather.unpack_dst_lb, gather 571 ompi/mca/coll/portals4/coll_portals4_gather.c &request->u.gather.unpack_dst_extent); gather 572 ompi/mca/coll/portals4/coll_portals4_gather.c ompi_datatype_get_true_extent(request->u.gather.unpack_dst_dtype, gather 573 ompi/mca/coll/portals4/coll_portals4_gather.c &request->u.gather.unpack_dst_true_lb, gather 574 ompi/mca/coll/portals4/coll_portals4_gather.c &request->u.gather.unpack_dst_true_extent); gather 576 ompi/mca/coll/portals4/coll_portals4_gather.c if ((root == request->u.gather.my_rank) && (sbuf == MPI_IN_PLACE)) { gather 577 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.pack_src_offset = request->u.gather.pack_src_extent * request->u.gather.pack_src_count * request->u.gather.my_rank; gather 583 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.pack_src_offset); gather 589 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.coll_count = opal_atomic_add_fetch_size_t(&portals4_module->coll_count, 1); gather 591 ompi/mca/coll/portals4/coll_portals4_gather.c COLL_PORTALS4_UPDATE_IN_ORDER_BMTREE( comm, portals4_module, request->u.gather.root_rank ); gather 594 ompi/mca/coll/portals4/coll_portals4_gather.c vrank = VRANK(request->u.gather.my_rank, request->u.gather.root_rank, request->u.gather.size); gather 607 ompi/mca/coll/portals4/coll_portals4_gather.c __FILE__, __LINE__, request->u.gather.packed_size, mca_coll_portals4_component.ni_limits.max_msg_size)); gather 610 ompi/mca/coll/portals4/coll_portals4_gather.c int child_vrank = VRANK(bmtree->tree_next[i], request->u.gather.root_rank, request->u.gather.size); gather 612 ompi/mca/coll/portals4/coll_portals4_gather.c ptl_size_t local_number_of_fragment = ((sub_tree_size * request->u.gather.packed_size) + mca_coll_portals4_component.ni_limits.max_msg_size -1) / mca_coll_portals4_component.ni_limits.max_msg_size; gather 616 ompi/mca/coll/portals4/coll_portals4_gather.c __FILE__, __LINE__, bmtree->tree_next[i], vrank, request->u.gather.root_rank , sub_tree_size, local_number_of_fragment)); gather 620 ompi/mca/coll/portals4/coll_portals4_gather.c number_of_fragment_send = (request->u.gather.gather_bytes + mca_coll_portals4_component.ni_limits.max_msg_size -1) / mca_coll_portals4_component.ni_limits.max_msg_size; gather 628 ompi/mca/coll/portals4/coll_portals4_gather.c ret = PtlTriggeredCTInc(request->u.gather.gather_cth, gather 630 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.sync_cth, gather 633 ompi/mca/coll/portals4/coll_portals4_gather.c ret = PtlTriggeredCTInc(request->u.gather.gather_cth, gather 635 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.sync_cth, gather 651 ompi/mca/coll/portals4/coll_portals4_gather.c int32_t vparent = VRANK(parent, request->u.gather.root_rank, request->u.gather.size); gather 653 ompi/mca/coll/portals4/coll_portals4_gather.c ptl_size_t remote_offset=(vrank-vparent) * request->u.gather.packed_size; gather 658 ompi/mca/coll/portals4/coll_portals4_gather.c remote_offset, vrank, vparent, request->u.gather.packed_size); gather 664 ompi/mca/coll/portals4/coll_portals4_gather.c ptl_size_t size_left = request->u.gather.gather_bytes; gather 670 ompi/mca/coll/portals4/coll_portals4_gather.c ret = PtlTriggeredPut(request->u.gather.gather_mdh, gather 671 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.gather_offset + size_sent, gather 676 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.gather_match_bits, gather 680 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.gather_cth, gather 693 ompi/mca/coll/portals4/coll_portals4_gather.c ret = PtlTriggeredPut(request->u.gather.sync_mdh, gather 699 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.sync_match_bits, gather 703 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.gather_cth, gather 710 ompi/mca/coll/portals4/coll_portals4_gather.c if (!request->u.gather.is_sync) { gather 718 ompi/mca/coll/portals4/coll_portals4_gather.c ompi_coll_portals4_get_peer(comm, request->u.gather.my_rank), gather 724 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.gather_cth, gather 735 ompi/mca/coll/portals4/coll_portals4_gather.c ret = PtlTriggeredPut(request->u.gather.sync_mdh, gather 741 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.sync_match_bits, gather 745 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.sync_cth, gather 755 ompi/mca/coll/portals4/coll_portals4_gather.c ret = PtlPut(request->u.gather.sync_mdh, gather 761 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.sync_match_bits, gather 769 ompi/mca/coll/portals4/coll_portals4_gather.c if (request->u.gather.is_sync) { gather 777 ompi/mca/coll/portals4/coll_portals4_gather.c ret = PtlCTWait(request->u.gather.gather_cth, expected_ops, &ct); gather 788 ompi/mca/coll/portals4/coll_portals4_gather.c "coll:portals4:gather_intra_binomial_top exit rank %d", request->u.gather.my_rank)); gather 793 ompi/mca/coll/portals4/coll_portals4_gather.c if (NULL != request->u.gather.gather_buf) gather 794 ompi/mca/coll/portals4/coll_portals4_gather.c free(request->u.gather.gather_buf); gather 800 ompi/mca/coll/portals4/coll_portals4_gather.c __FILE__, __LINE__, line, ret, request->u.gather.my_rank); gather 829 ompi/mca/coll/portals4/coll_portals4_gather.c "coll:portals4:gather_intra_linear_top enter rank %d", request->u.gather.my_rank)); gather 832 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.gather_buf=NULL; gather 833 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.gather_mdh=PTL_INVALID_HANDLE; gather 834 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.gather_cth=PTL_INVALID_HANDLE; gather 835 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.gather_meh=PTL_INVALID_HANDLE; gather 836 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.sync_mdh=PTL_INVALID_HANDLE; gather 837 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.sync_cth=PTL_INVALID_HANDLE; gather 838 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.sync_meh=PTL_INVALID_HANDLE; gather 840 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.my_rank = ompi_comm_rank(comm); gather 841 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.size = ompi_comm_size(comm); gather 842 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.root_rank = root; gather 843 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.sbuf = sbuf; gather 844 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.rbuf = rbuf; gather 845 ompi/mca/coll/portals4/coll_portals4_gather.c if ((root == request->u.gather.my_rank) && (sbuf == MPI_IN_PLACE)) { gather 846 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.pack_src_buf = rbuf; gather 847 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.pack_src_count = rcount; gather 848 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.pack_src_dtype = rdtype; gather 850 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.pack_src_buf = sbuf; gather 851 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.pack_src_count = scount; gather 852 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.pack_src_dtype = sdtype; gather 853 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.pack_src_offset = 0; gather 855 ompi/mca/coll/portals4/coll_portals4_gather.c ompi_datatype_get_extent(request->u.gather.pack_src_dtype, gather 856 ompi/mca/coll/portals4/coll_portals4_gather.c &request->u.gather.pack_src_lb, gather 857 ompi/mca/coll/portals4/coll_portals4_gather.c &request->u.gather.pack_src_extent); gather 858 ompi/mca/coll/portals4/coll_portals4_gather.c ompi_datatype_get_true_extent(request->u.gather.pack_src_dtype, gather 859 ompi/mca/coll/portals4/coll_portals4_gather.c &request->u.gather.pack_src_true_lb, gather 860 ompi/mca/coll/portals4/coll_portals4_gather.c &request->u.gather.pack_src_true_extent); gather 861 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.unpack_dst_buf = rbuf; gather 862 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.unpack_dst_count = rcount; gather 863 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.unpack_dst_dtype = rdtype; gather 864 ompi/mca/coll/portals4/coll_portals4_gather.c ompi_datatype_get_extent(request->u.gather.unpack_dst_dtype, gather 865 ompi/mca/coll/portals4/coll_portals4_gather.c &request->u.gather.unpack_dst_lb, gather 866 ompi/mca/coll/portals4/coll_portals4_gather.c &request->u.gather.unpack_dst_extent); gather 867 ompi/mca/coll/portals4/coll_portals4_gather.c ompi_datatype_get_true_extent(request->u.gather.unpack_dst_dtype, gather 868 ompi/mca/coll/portals4/coll_portals4_gather.c &request->u.gather.unpack_dst_true_lb, gather 869 ompi/mca/coll/portals4/coll_portals4_gather.c &request->u.gather.unpack_dst_true_extent); gather 871 ompi/mca/coll/portals4/coll_portals4_gather.c if ((root == request->u.gather.my_rank) && (sbuf == MPI_IN_PLACE)) { gather 872 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.pack_src_offset = request->u.gather.pack_src_extent * request->u.gather.pack_src_count * request->u.gather.my_rank; gather 877 ompi/mca/coll/portals4/coll_portals4_gather.c __FILE__, __LINE__, request->u.gather.my_rank, gather 878 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.pack_src_offset); gather 884 ompi/mca/coll/portals4/coll_portals4_gather.c i_am_root = (request->u.gather.my_rank == request->u.gather.root_rank); gather 886 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.coll_count = opal_atomic_add_fetch_size_t(&portals4_module->coll_count, 1); gather 897 ompi/mca/coll/portals4/coll_portals4_gather.c number_of_fragment = (request->u.gather.packed_size > mca_coll_portals4_component.ni_limits.max_msg_size) ? gather 898 ompi/mca/coll/portals4/coll_portals4_gather.c (request->u.gather.packed_size + mca_coll_portals4_component.ni_limits.max_msg_size - 1) / mca_coll_portals4_component.ni_limits.max_msg_size : gather 902 ompi/mca/coll/portals4/coll_portals4_gather.c __FILE__, __LINE__, request->u.gather.my_rank, number_of_fragment); gather 910 ompi/mca/coll/portals4/coll_portals4_gather.c ret = PtlTriggeredCTInc(request->u.gather.gather_cth, gather 912 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.sync_cth, gather 915 ompi/mca/coll/portals4/coll_portals4_gather.c ret = PtlTriggeredCTInc(request->u.gather.gather_cth, gather 917 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.sync_cth, gather 928 ompi/mca/coll/portals4/coll_portals4_gather.c expected_ops=(request->u.gather.size-1) * number_of_fragment; /* gather put from all other ranks */ gather 932 ompi/mca/coll/portals4/coll_portals4_gather.c ptl_size_t remote_offset=request->u.gather.my_rank * request->u.gather.packed_size; gather 934 ompi/mca/coll/portals4/coll_portals4_gather.c ptl_size_t size_left = request->u.gather.gather_bytes; gather 938 ompi/mca/coll/portals4/coll_portals4_gather.c __FILE__, __LINE__, request->u.gather.my_rank, gather 939 ompi/mca/coll/portals4/coll_portals4_gather.c remote_offset, request->u.gather.my_rank, request->u.gather.packed_size); gather 952 ompi/mca/coll/portals4/coll_portals4_gather.c __FILE__, __LINE__, request->u.gather.my_rank, gather 955 ompi/mca/coll/portals4/coll_portals4_gather.c ret = PtlTriggeredPut(request->u.gather.gather_mdh, gather 956 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.gather_offset + split_offset, gather 959 ompi/mca/coll/portals4/coll_portals4_gather.c ompi_coll_portals4_get_peer(comm, request->u.gather.root_rank), gather 961 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.gather_match_bits, gather 965 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.gather_cth, gather 978 ompi/mca/coll/portals4/coll_portals4_gather.c for (i=0;i<request->u.gather.size;i++) { gather 979 ompi/mca/coll/portals4/coll_portals4_gather.c if (i == request->u.gather.root_rank) { continue; } gather 980 ompi/mca/coll/portals4/coll_portals4_gather.c ret = PtlTriggeredPut(request->u.gather.sync_mdh, gather 986 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.sync_match_bits, gather 990 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.gather_cth, gather 998 ompi/mca/coll/portals4/coll_portals4_gather.c if (!request->u.gather.is_sync) { gather 1006 ompi/mca/coll/portals4/coll_portals4_gather.c ompi_coll_portals4_get_peer(comm, request->u.gather.my_rank), gather 1012 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.gather_cth, gather 1022 ompi/mca/coll/portals4/coll_portals4_gather.c for (i=0;i<request->u.gather.size;i++) { gather 1023 ompi/mca/coll/portals4/coll_portals4_gather.c if (i == request->u.gather.root_rank) { continue; } gather 1024 ompi/mca/coll/portals4/coll_portals4_gather.c ret = PtlTriggeredPut(request->u.gather.sync_mdh, gather 1030 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.sync_match_bits, gather 1034 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.sync_cth, gather 1044 ompi/mca/coll/portals4/coll_portals4_gather.c for (i=0;i<request->u.gather.size;i++) { gather 1045 ompi/mca/coll/portals4/coll_portals4_gather.c if (i == request->u.gather.root_rank) { continue; } gather 1046 ompi/mca/coll/portals4/coll_portals4_gather.c ret = PtlPut(request->u.gather.sync_mdh, gather 1052 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.sync_match_bits, gather 1061 ompi/mca/coll/portals4/coll_portals4_gather.c if (request->u.gather.is_sync) { gather 1068 ompi/mca/coll/portals4/coll_portals4_gather.c ret = PtlCTWait(request->u.gather.gather_cth, expected_ops, &ct); gather 1076 ompi/mca/coll/portals4/coll_portals4_gather.c "coll:portals4:gather_intra_linear_top exit rank %d", request->u.gather.my_rank)); gather 1081 ompi/mca/coll/portals4/coll_portals4_gather.c if (NULL != request->u.gather.gather_buf) gather 1082 ompi/mca/coll/portals4/coll_portals4_gather.c free(request->u.gather.gather_buf); gather 1086 ompi/mca/coll/portals4/coll_portals4_gather.c __FILE__, __LINE__, line, ret, request->u.gather.my_rank); gather 1099 ompi/mca/coll/portals4/coll_portals4_gather.c "coll:portals4:gather_intra_binomial_bottom enter rank %d", request->u.gather.my_rank)); gather 1107 ompi/mca/coll/portals4/coll_portals4_gather.c if (request->u.gather.my_rank == request->u.gather.root_rank) { gather 1112 ompi/mca/coll/portals4/coll_portals4_gather.c for (i=0;i<request->u.gather.size;i++) { gather 1113 ompi/mca/coll/portals4/coll_portals4_gather.c uint64_t offset = request->u.gather.unpack_dst_extent * request->u.gather.unpack_dst_count * ((request->u.gather.my_rank + i) % request->u.gather.size); gather 1117 ompi/mca/coll/portals4/coll_portals4_gather.c __FILE__, __LINE__, request->u.gather.my_rank, gather 1120 ompi/mca/coll/portals4/coll_portals4_gather.c ompi_coll_portals4_create_recv_converter (&request->u.gather.recv_converter, gather 1121 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.unpack_dst_buf + offset, gather 1122 ompi/mca/coll/portals4/coll_portals4_gather.c ompi_comm_peer_lookup(comm, request->u.gather.my_rank), gather 1123 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.unpack_dst_count, gather 1124 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.unpack_dst_dtype); gather 1126 ompi/mca/coll/portals4/coll_portals4_gather.c iov.iov_len = request->u.gather.packed_size; gather 1127 ompi/mca/coll/portals4/coll_portals4_gather.c iov.iov_base = (IOVBASE_TYPE *) ((char *)request->u.gather.gather_buf + (request->u.gather.packed_size*i)); gather 1128 ompi/mca/coll/portals4/coll_portals4_gather.c opal_convertor_unpack(&request->u.gather.recv_converter, &iov, &iov_count, &max_data); gather 1130 ompi/mca/coll/portals4/coll_portals4_gather.c OBJ_DESTRUCT(&request->u.gather.recv_converter); gather 1134 ompi/mca/coll/portals4/coll_portals4_gather.c if (request->u.gather.free_after) gather 1135 ompi/mca/coll/portals4/coll_portals4_gather.c free(request->u.gather.gather_buf); gather 1142 ompi/mca/coll/portals4/coll_portals4_gather.c "coll:portals4:gather_intra_binomial_bottom exit rank %d", request->u.gather.my_rank)); gather 1149 ompi/mca/coll/portals4/coll_portals4_gather.c if (request->u.gather.free_after) gather 1150 ompi/mca/coll/portals4/coll_portals4_gather.c free(request->u.gather.gather_buf); gather 1154 ompi/mca/coll/portals4/coll_portals4_gather.c __FILE__, __LINE__, line, ret, request->u.gather.my_rank); gather 1167 ompi/mca/coll/portals4/coll_portals4_gather.c "coll:portals4:gather_intra_linear_bottom enter rank %d", request->u.gather.my_rank)); gather 1175 ompi/mca/coll/portals4/coll_portals4_gather.c if (request->u.gather.my_rank == request->u.gather.root_rank) { gather 1180 ompi/mca/coll/portals4/coll_portals4_gather.c for (i=0;i<request->u.gather.size;i++) { gather 1181 ompi/mca/coll/portals4/coll_portals4_gather.c ompi_coll_portals4_create_recv_converter (&request->u.gather.recv_converter, gather 1182 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.unpack_dst_buf + (request->u.gather.unpack_dst_extent*request->u.gather.unpack_dst_count*i), gather 1183 ompi/mca/coll/portals4/coll_portals4_gather.c ompi_comm_peer_lookup(comm, request->u.gather.my_rank), gather 1184 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.unpack_dst_count, gather 1185 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.unpack_dst_dtype); gather 1187 ompi/mca/coll/portals4/coll_portals4_gather.c iov.iov_len = request->u.gather.packed_size; gather 1188 ompi/mca/coll/portals4/coll_portals4_gather.c iov.iov_base = (IOVBASE_TYPE *) ((char *)request->u.gather.gather_buf + (request->u.gather.packed_size*i)); gather 1189 ompi/mca/coll/portals4/coll_portals4_gather.c opal_convertor_unpack(&request->u.gather.recv_converter, &iov, &iov_count, &max_data); gather 1191 ompi/mca/coll/portals4/coll_portals4_gather.c OBJ_DESTRUCT(&request->u.gather.recv_converter); gather 1195 ompi/mca/coll/portals4/coll_portals4_gather.c if (request->u.gather.free_after) gather 1196 ompi/mca/coll/portals4/coll_portals4_gather.c free(request->u.gather.gather_buf); gather 1203 ompi/mca/coll/portals4/coll_portals4_gather.c "coll:portals4:gather_intra_linear_bottom exit rank %d", request->u.gather.my_rank)); gather 1210 ompi/mca/coll/portals4/coll_portals4_gather.c if (request->u.gather.free_after) gather 1211 ompi/mca/coll/portals4/coll_portals4_gather.c free(request->u.gather.gather_buf); gather 1215 ompi/mca/coll/portals4/coll_portals4_gather.c __FILE__, __LINE__, line, ret, request->u.gather.my_rank); gather 1241 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.is_sync = 1; gather 1279 ompi/mca/coll/portals4/coll_portals4_gather.c "coll:portals4:gather_intra exit rank %d", request->u.gather.my_rank)); gather 1286 ompi/mca/coll/portals4/coll_portals4_gather.c __FILE__, __LINE__, line, ret, request->u.gather.my_rank); gather 1315 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.is_sync = 0; gather 1342 ompi/mca/coll/portals4/coll_portals4_gather.c "coll:portals4:igather_intra exit rank %d", request->u.gather.my_rank)); gather 1349 ompi/mca/coll/portals4/coll_portals4_gather.c __FILE__, __LINE__, line, ret, request->u.gather.my_rank); gather 1361 ompi/mca/coll/portals4/coll_portals4_gather.c "coll:portals4:igather_intra_fini enter rank %d", request->u.gather.my_rank)); gather 1375 ompi/mca/coll/portals4/coll_portals4_gather.c "coll:portals4:igather_intra_fini exit rank %d", request->u.gather.my_rank)); gather 1382 ompi/mca/coll/portals4/coll_portals4_gather.c __FILE__, __LINE__, line, ret, request->u.gather.my_rank); gather 124 ompi/mca/coll/portals4/coll_portals4_request.h } gather; gather 161 ompi/mca/coll/sync/coll_sync_module.c CHECK_AND_RETAIN(gather); gather 1336 ompi/mpi/java/java/Comm.java gather(handle, sendbuf, sdb, sendoff, sendcount, gather 1367 ompi/mpi/java/java/Comm.java gather(handle, null, false, 0, 0, 0, 0, gather 145 ompi/runtime/ompi_cr.c SIGNAL(comm, modules, highest_module, msg, ret, gather);