bcast 165 ompi/mca/coll/base/coll_base_comm_select.c COPY(avail->ac_module, comm, bcast); bcast 250 ompi/mca/coll/base/coll_base_comm_select.c CHECK_NULL(which_func, comm, bcast) || bcast 60 ompi/mca/coll/base/coll_base_comm_unselect.c CLOSE(comm, bcast); bcast 128 ompi/mca/coll/demo/coll_demo_component.c RELEASE(module, bcast); bcast 194 ompi/mca/coll/demo/coll_demo_module.c COPY(comm, demo_module, bcast); bcast 174 ompi/mca/coll/hcoll/coll_hcoll_module.c HCOL_SAVE_PREV_COLL_API(bcast); bcast 72 ompi/mca/coll/monitoring/coll_monitoring_component.c operation(m, c, bcast); \ bcast 43 ompi/mca/coll/portals4/coll_portals4_bcast.c request->u.bcast.is_root = (rank == root); bcast 44 ompi/mca/coll/portals4/coll_portals4_bcast.c request->u.bcast.needs_pack = !ompi_datatype_is_contiguous_memory_layout(datatype, count); bcast 46 ompi/mca/coll/portals4/coll_portals4_bcast.c if (request->u.bcast.needs_pack) { bcast 47 ompi/mca/coll/portals4/coll_portals4_bcast.c if (request->u.bcast.is_root) { bcast 48 ompi/mca/coll/portals4/coll_portals4_bcast.c OBJ_CONSTRUCT(&request->u.bcast.convertor, opal_convertor_t); bcast 51 ompi/mca/coll/portals4/coll_portals4_bcast.c buff, 0, &request->u.bcast.convertor); bcast 52 ompi/mca/coll/portals4/coll_portals4_bcast.c opal_convertor_get_packed_size(&request->u.bcast.convertor, &request->u.bcast.tmpsize); bcast 53 ompi/mca/coll/portals4/coll_portals4_bcast.c request->u.bcast.tmpbuf = malloc(request->u.bcast.tmpsize); bcast 54 ompi/mca/coll/portals4/coll_portals4_bcast.c if (OPAL_UNLIKELY(NULL == request->u.bcast.tmpbuf)) { bcast 55 ompi/mca/coll/portals4/coll_portals4_bcast.c OBJ_DESTRUCT(&request->u.bcast.convertor); bcast 59 ompi/mca/coll/portals4/coll_portals4_bcast.c iovec.iov_base = request->u.bcast.tmpbuf; bcast 60 ompi/mca/coll/portals4/coll_portals4_bcast.c iovec.iov_len = request->u.bcast.tmpsize; bcast 62 ompi/mca/coll/portals4/coll_portals4_bcast.c max_data = request->u.bcast.tmpsize; bcast 63 ompi/mca/coll/portals4/coll_portals4_bcast.c ret = opal_convertor_pack(&request->u.bcast.convertor, &iovec, &iov_count, &max_data); bcast 64 ompi/mca/coll/portals4/coll_portals4_bcast.c OBJ_DESTRUCT(&request->u.bcast.convertor); bcast 69 ompi/mca/coll/portals4/coll_portals4_bcast.c OBJ_CONSTRUCT(&request->u.bcast.convertor, opal_convertor_t); bcast 72 ompi/mca/coll/portals4/coll_portals4_bcast.c buff, 0, &request->u.bcast.convertor); bcast 74 ompi/mca/coll/portals4/coll_portals4_bcast.c max_data = request->u.bcast.tmpsize; bcast 75 ompi/mca/coll/portals4/coll_portals4_bcast.c opal_convertor_get_packed_size(&request->u.bcast.convertor, &max_data); bcast 77 ompi/mca/coll/portals4/coll_portals4_bcast.c request->u.bcast.tmpbuf = malloc(request->u.bcast.tmpsize); bcast 78 ompi/mca/coll/portals4/coll_portals4_bcast.c if (OPAL_UNLIKELY(NULL == request->u.bcast.tmpbuf)) { bcast 79 ompi/mca/coll/portals4/coll_portals4_bcast.c OBJ_DESTRUCT(&request->u.bcast.convertor); bcast 85 ompi/mca/coll/portals4/coll_portals4_bcast.c request->u.bcast.tmpbuf = buff; bcast 87 ompi/mca/coll/portals4/coll_portals4_bcast.c ompi_datatype_type_size(datatype, &request->u.bcast.tmpsize); bcast 88 ompi/mca/coll/portals4/coll_portals4_bcast.c request->u.bcast.tmpsize *= count; bcast 98 ompi/mca/coll/portals4/coll_portals4_bcast.c request->u.bcast.segment_nb = (request->u.bcast.tmpsize > max_msg_size) ? bcast 99 ompi/mca/coll/portals4/coll_portals4_bcast.c (((request->u.bcast.tmpsize + max_msg_size -1) / max_msg_size) < COLL_PORTALS4_MAX_SEGMENT ? bcast 100 ompi/mca/coll/portals4/coll_portals4_bcast.c ((request->u.bcast.tmpsize + max_msg_size -1) / max_msg_size) : COLL_PORTALS4_MAX_SEGMENT) : bcast 104 ompi/mca/coll/portals4/coll_portals4_bcast.c "seg_number=%d , seg_size_max=%lu", request->u.bcast.segment_nb, max_msg_size)); bcast 106 ompi/mca/coll/portals4/coll_portals4_bcast.c if (request->u.bcast.segment_nb > COLL_PORTALS4_BCAST_ALGO_THRESHOLD) { bcast 107 ompi/mca/coll/portals4/coll_portals4_bcast.c request->u.bcast.algo = OMPI_COLL_PORTALS4_BCAST_PIPELINE_ALGO; bcast 110 ompi/mca/coll/portals4/coll_portals4_bcast.c request->u.bcast.algo = OMPI_COLL_PORTALS4_BCAST_KARY_TREE_ALGO; bcast 122 ompi/mca/coll/portals4/coll_portals4_bcast.c if (request->u.bcast.needs_pack) { bcast 123 ompi/mca/coll/portals4/coll_portals4_bcast.c if (!request->u.bcast.is_root) { bcast 124 ompi/mca/coll/portals4/coll_portals4_bcast.c opal_convertor_get_packed_size(&request->u.bcast.convertor, &request->u.bcast.tmpsize); bcast 126 ompi/mca/coll/portals4/coll_portals4_bcast.c iovec.iov_base = request->u.bcast.tmpbuf; bcast 127 ompi/mca/coll/portals4/coll_portals4_bcast.c iovec.iov_len = request->u.bcast.tmpsize; bcast 129 ompi/mca/coll/portals4/coll_portals4_bcast.c ret = opal_convertor_unpack(&request->u.bcast.convertor, &iovec, &iov_count, &max_data); bcast 130 ompi/mca/coll/portals4/coll_portals4_bcast.c OBJ_DESTRUCT(&request->u.bcast.convertor); bcast 135 ompi/mca/coll/portals4/coll_portals4_bcast.c free(request->u.bcast.tmpbuf); bcast 150 ompi/mca/coll/portals4/coll_portals4_bcast.c unsigned int segment_nb = request->u.bcast.segment_nb; bcast 188 ompi/mca/coll/portals4/coll_portals4_bcast.c request->u.bcast.u.child_nb = child_nb; bcast 198 ompi/mca/coll/portals4/coll_portals4_bcast.c if ((ret = PtlCTAlloc(mca_coll_portals4_component.ni_h, &request->u.bcast.trig_ct_h)) != 0) { bcast 216 ompi/mca/coll/portals4/coll_portals4_bcast.c seg_size = request->u.bcast.tmpsize / segment_nb; bcast 217 ompi/mca/coll/portals4/coll_portals4_bcast.c nb_long = request->u.bcast.tmpsize % segment_nb; bcast 234 ompi/mca/coll/portals4/coll_portals4_bcast.c me.start = ((uint8_t*) request->u.bcast.tmpbuf) + offset; bcast 236 ompi/mca/coll/portals4/coll_portals4_bcast.c me.ct_handle = request->u.bcast.trig_ct_h; bcast 285 ompi/mca/coll/portals4/coll_portals4_bcast.c request->u.bcast.trig_ct_h, trig_thr)) != 0) { bcast 291 ompi/mca/coll/portals4/coll_portals4_bcast.c if ((ret = PtlCTAlloc(mca_coll_portals4_component.ni_h, &request->u.bcast.rtr_ct_h)) != 0) { bcast 297 ompi/mca/coll/portals4/coll_portals4_bcast.c if ((ret = PtlTriggeredCTInc(request->u.bcast.trig_ct_h, ct_inc, bcast 298 ompi/mca/coll/portals4/coll_portals4_bcast.c request->u.bcast.rtr_ct_h, child_nb)) != 0) { bcast 302 ompi/mca/coll/portals4/coll_portals4_bcast.c if ((ret = PtlCTAlloc(mca_coll_portals4_component.ni_h, &request->u.bcast.ack_ct_h)) != 0) { bcast 324 ompi/mca/coll/portals4/coll_portals4_bcast.c me.ct_handle = request->u.bcast.ack_ct_h; bcast 353 ompi/mca/coll/portals4/coll_portals4_bcast.c me.ct_handle = request->u.bcast.rtr_ct_h; bcast 387 ompi/mca/coll/portals4/coll_portals4_bcast.c (uint64_t) request->u.bcast.tmpbuf + offset, bcast 393 ompi/mca/coll/portals4/coll_portals4_bcast.c 0, request->u.bcast.trig_ct_h, trig_thr)) != 0) { bcast 405 ompi/mca/coll/portals4/coll_portals4_bcast.c if ((ret = PtlTriggeredCTInc(request->u.bcast.trig_ct_h, ct_inc, bcast 406 ompi/mca/coll/portals4/coll_portals4_bcast.c request->u.bcast.trig_ct_h, trig_thr)) != 0) { bcast 414 ompi/mca/coll/portals4/coll_portals4_bcast.c if ((ret = PtlCTWait(request->u.bcast.ack_ct_h, ack_thr, &ct)) != 0) bcast 422 ompi/mca/coll/portals4/coll_portals4_bcast.c request->u.bcast.ack_ct_h, bcast 430 ompi/mca/coll/portals4/coll_portals4_bcast.c request->u.bcast.rtr_ct_h = PTL_INVALID_HANDLE; bcast 431 ompi/mca/coll/portals4/coll_portals4_bcast.c request->u.bcast.ack_ct_h = PTL_INVALID_HANDLE; bcast 450 ompi/mca/coll/portals4/coll_portals4_bcast.c if ((ret = PtlTriggeredCTInc(request->u.bcast.trig_ct_h, ct_inc, bcast 451 ompi/mca/coll/portals4/coll_portals4_bcast.c request->u.bcast.trig_ct_h, trig_thr)) != 0) { bcast 455 ompi/mca/coll/portals4/coll_portals4_bcast.c if ((ret = PtlTriggeredCTInc(request->u.bcast.trig_ct_h, ct_inc, bcast 456 ompi/mca/coll/portals4/coll_portals4_bcast.c request->u.bcast.trig_ct_h, trig_thr + 1)) != 0) { bcast 460 ompi/mca/coll/portals4/coll_portals4_bcast.c if ((ret = PtlCTWait(request->u.bcast.trig_ct_h, trig_thr + 2, &ct)) != 0) { bcast 469 ompi/mca/coll/portals4/coll_portals4_bcast.c request->u.bcast.trig_ct_h, bcast 491 ompi/mca/coll/portals4/coll_portals4_bcast.c unsigned int segment_nb = request->u.bcast.segment_nb; bcast 523 ompi/mca/coll/portals4/coll_portals4_bcast.c request->u.bcast.u.child = child; bcast 529 ompi/mca/coll/portals4/coll_portals4_bcast.c if ((ret = PtlCTAlloc(mca_coll_portals4_component.ni_h, &request->u.bcast.trig_ct_h)) != 0) { bcast 546 ompi/mca/coll/portals4/coll_portals4_bcast.c seg_size = request->u.bcast.tmpsize / segment_nb; bcast 547 ompi/mca/coll/portals4/coll_portals4_bcast.c nb_long = request->u.bcast.tmpsize % segment_nb; bcast 564 ompi/mca/coll/portals4/coll_portals4_bcast.c me.start = ((uint8_t*) request->u.bcast.tmpbuf) + offset; bcast 566 ompi/mca/coll/portals4/coll_portals4_bcast.c me.ct_handle = request->u.bcast.trig_ct_h; bcast 616 ompi/mca/coll/portals4/coll_portals4_bcast.c request->u.bcast.trig_ct_h, trig_thr)) != 0) { bcast 622 ompi/mca/coll/portals4/coll_portals4_bcast.c if ((ret = PtlCTAlloc(mca_coll_portals4_component.ni_h, &request->u.bcast.rtr_ct_h)) != 0) { bcast 629 ompi/mca/coll/portals4/coll_portals4_bcast.c if ((ret = PtlTriggeredCTInc(request->u.bcast.trig_ct_h, ct_inc, bcast 630 ompi/mca/coll/portals4/coll_portals4_bcast.c request->u.bcast.rtr_ct_h, 1)) != 0) { bcast 634 ompi/mca/coll/portals4/coll_portals4_bcast.c if ((ret = PtlCTAlloc(mca_coll_portals4_component.ni_h, &request->u.bcast.ack_ct_h)) != 0) { bcast 656 ompi/mca/coll/portals4/coll_portals4_bcast.c me.ct_handle = request->u.bcast.ack_ct_h; bcast 683 ompi/mca/coll/portals4/coll_portals4_bcast.c me.ct_handle = request->u.bcast.rtr_ct_h; bcast 714 ompi/mca/coll/portals4/coll_portals4_bcast.c (uint64_t) request->u.bcast.tmpbuf + offset, bcast 720 ompi/mca/coll/portals4/coll_portals4_bcast.c 0, request->u.bcast.trig_ct_h, trig_thr)) != 0) { bcast 730 ompi/mca/coll/portals4/coll_portals4_bcast.c if ((ret = PtlTriggeredCTInc(request->u.bcast.trig_ct_h, ct_inc, bcast 731 ompi/mca/coll/portals4/coll_portals4_bcast.c request->u.bcast.trig_ct_h, trig_thr)) != 0) { bcast 737 ompi/mca/coll/portals4/coll_portals4_bcast.c if ((ret = PtlCTWait(request->u.bcast.ack_ct_h, 1, &ct)) != 0) { bcast 746 ompi/mca/coll/portals4/coll_portals4_bcast.c request->u.bcast.ack_ct_h, bcast 754 ompi/mca/coll/portals4/coll_portals4_bcast.c request->u.bcast.rtr_ct_h = PTL_INVALID_HANDLE; bcast 755 ompi/mca/coll/portals4/coll_portals4_bcast.c request->u.bcast.ack_ct_h = PTL_INVALID_HANDLE; bcast 775 ompi/mca/coll/portals4/coll_portals4_bcast.c if ((ret = PtlTriggeredCTInc(request->u.bcast.trig_ct_h, ct_inc, bcast 776 ompi/mca/coll/portals4/coll_portals4_bcast.c request->u.bcast.trig_ct_h, trig_thr)) != 0) { bcast 780 ompi/mca/coll/portals4/coll_portals4_bcast.c if ((ret = PtlTriggeredCTInc(request->u.bcast.trig_ct_h, ct_inc, bcast 781 ompi/mca/coll/portals4/coll_portals4_bcast.c request->u.bcast.trig_ct_h, trig_thr + 1)) != 0) { bcast 785 ompi/mca/coll/portals4/coll_portals4_bcast.c if ((ret = PtlCTWait(request->u.bcast.trig_ct_h, trig_thr + 2, &ct)) != 0) { bcast 794 ompi/mca/coll/portals4/coll_portals4_bcast.c request->u.bcast.trig_ct_h, bcast 811 ompi/mca/coll/portals4/coll_portals4_bcast.c if (request->u.bcast.u.child_nb) { bcast 812 ompi/mca/coll/portals4/coll_portals4_bcast.c PtlCTFree(request->u.bcast.rtr_ct_h); bcast 813 ompi/mca/coll/portals4/coll_portals4_bcast.c PtlCTFree(request->u.bcast.ack_ct_h); bcast 816 ompi/mca/coll/portals4/coll_portals4_bcast.c PtlCTFree(request->u.bcast.trig_ct_h); bcast 826 ompi/mca/coll/portals4/coll_portals4_bcast.c if (request->u.bcast.u.child != PTL_INVALID_RANK) { bcast 827 ompi/mca/coll/portals4/coll_portals4_bcast.c PtlCTFree(request->u.bcast.rtr_ct_h); bcast 828 ompi/mca/coll/portals4/coll_portals4_bcast.c PtlCTFree(request->u.bcast.ack_ct_h); bcast 831 ompi/mca/coll/portals4/coll_portals4_bcast.c PtlCTFree(request->u.bcast.trig_ct_h); bcast 856 ompi/mca/coll/portals4/coll_portals4_bcast.c switch (request->u.bcast.algo) { bcast 870 ompi/mca/coll/portals4/coll_portals4_bcast.c __FILE__, __LINE__, request->u.bcast.algo); bcast 903 ompi/mca/coll/portals4/coll_portals4_bcast.c switch (request->u.bcast.algo) { bcast 915 ompi/mca/coll/portals4/coll_portals4_bcast.c __FILE__, __LINE__, request->u.bcast.algo); bcast 928 ompi/mca/coll/portals4/coll_portals4_bcast.c switch (request->u.bcast.algo) { bcast 938 ompi/mca/coll/portals4/coll_portals4_bcast.c __FILE__, __LINE__, request->u.bcast.algo); bcast 66 ompi/mca/coll/portals4/coll_portals4_request.h } bcast; bcast 160 ompi/mca/coll/sync/coll_sync_module.c CHECK_AND_RETAIN(bcast); bcast 1267 ompi/mpi/java/java/Comm.java bcast(handle, buf, db, off, count, type.handle, type.baseType, root); bcast 143 ompi/runtime/ompi_cr.c SIGNAL(comm, modules, highest_module, msg, ret, bcast);