schedule 94 ompi/communicator/comm_request.c opal_list_append (&request->schedule, &request_item->super); schedule 114 ompi/communicator/comm_request.c if (opal_list_get_size (&request->schedule)) { schedule 115 ompi/communicator/comm_request.c ompi_comm_request_item_t *request_item = (ompi_comm_request_item_t *) opal_list_remove_first (&request->schedule); schedule 145 ompi/communicator/comm_request.c opal_list_prepend (&request->schedule, &request_item->super); schedule 150 ompi/communicator/comm_request.c if (0 == opal_list_get_size (&request->schedule)) { schedule 193 ompi/communicator/comm_request.c OPAL_LIST_FOREACH_SAFE(item, next, &request->schedule, ompi_comm_request_item_t) { schedule 198 ompi/communicator/comm_request.c opal_list_remove_item (&request->schedule, &item->super); schedule 240 ompi/communicator/comm_request.c OBJ_CONSTRUCT(&request->schedule, opal_list_t); schedule 245 ompi/communicator/comm_request.c OBJ_DESTRUCT(&request->schedule); schedule 25 ompi/communicator/comm_request.h opal_list_t schedule; schedule 132 ompi/mca/coll/libnbc/coll_libnbc.h NBC_Schedule *schedule; schedule 517 ompi/mca/coll/libnbc/coll_libnbc_component.c NBC_Schedule *schedule = handle->schedule; schedule 520 ompi/mca/coll/libnbc/coll_libnbc_component.c NBC_DEBUG(5, "schedule %p size %u\n", &schedule, sizeof(schedule)); schedule 522 ompi/mca/coll/libnbc/coll_libnbc_component.c NBC_DEBUG(5, "data %p size %u\n", &schedule->data, sizeof(schedule->data)); schedule 47 ompi/mca/coll/libnbc/nbc.c static void nbc_schedule_constructor (NBC_Schedule *schedule) { schedule 49 ompi/mca/coll/libnbc/nbc.c schedule->size = sizeof (int); schedule 50 ompi/mca/coll/libnbc/nbc.c schedule->current_round_offset = 0; schedule 51 ompi/mca/coll/libnbc/nbc.c schedule->data = calloc (1, schedule->size); schedule 54 ompi/mca/coll/libnbc/nbc.c static void nbc_schedule_destructor (NBC_Schedule *schedule) { schedule 55 ompi/mca/coll/libnbc/nbc.c free (schedule->data); schedule 56 ompi/mca/coll/libnbc/nbc.c schedule->data = NULL; schedule 62 ompi/mca/coll/libnbc/nbc.c static int nbc_schedule_grow (NBC_Schedule *schedule, int additional) { schedule 67 ompi/mca/coll/libnbc/nbc.c size = nbc_schedule_get_size (schedule); schedule 69 ompi/mca/coll/libnbc/nbc.c tmp = realloc (schedule->data, size + additional); schedule 75 ompi/mca/coll/libnbc/nbc.c schedule->data = tmp; schedule 79 ompi/mca/coll/libnbc/nbc.c static int nbc_schedule_round_append (NBC_Schedule *schedule, void *data, int data_size, bool barrier) { schedule 80 ompi/mca/coll/libnbc/nbc.c int ret, size = nbc_schedule_get_size (schedule); schedule 83 ompi/mca/coll/libnbc/nbc.c ret = nbc_schedule_grow (schedule, data_size + 1 + sizeof (int)); schedule 85 ompi/mca/coll/libnbc/nbc.c ret = nbc_schedule_grow (schedule, data_size); schedule 93 ompi/mca/coll/libnbc/nbc.c memcpy (schedule->data + size, data, data_size); schedule 96 ompi/mca/coll/libnbc/nbc.c nbc_schedule_inc_round (schedule); schedule 99 ompi/mca/coll/libnbc/nbc.c nbc_schedule_inc_size (schedule, data_size); schedule 104 ompi/mca/coll/libnbc/nbc.c schedule->data[size + data_size] = 1; schedule 106 ompi/mca/coll/libnbc/nbc.c memset (schedule->data + size + data_size + 1, 0, sizeof (int)); schedule 110 ompi/mca/coll/libnbc/nbc.c schedule->current_round_offset = size + data_size + 1; schedule 113 ompi/mca/coll/libnbc/nbc.c nbc_schedule_inc_size (schedule, sizeof (int) + 1); schedule 120 ompi/mca/coll/libnbc/nbc.c static int NBC_Sched_send_internal (const void* buf, char tmpbuf, int count, MPI_Datatype datatype, int dest, bool local, NBC_Schedule *schedule, bool barrier) { schedule 134 ompi/mca/coll/libnbc/nbc.c ret = nbc_schedule_round_append (schedule, &send_args, sizeof (send_args), barrier); schedule 139 ompi/mca/coll/libnbc/nbc.c NBC_DEBUG(10, "added send - ends at byte %i\n", nbc_schedule_get_size (schedule)); schedule 144 ompi/mca/coll/libnbc/nbc.c int NBC_Sched_send (const void* buf, char tmpbuf, int count, MPI_Datatype datatype, int dest, NBC_Schedule *schedule, bool barrier) { schedule 145 ompi/mca/coll/libnbc/nbc.c return NBC_Sched_send_internal (buf, tmpbuf, count, datatype, dest, false, schedule, barrier); schedule 148 ompi/mca/coll/libnbc/nbc.c int NBC_Sched_local_send (const void* buf, char tmpbuf, int count, MPI_Datatype datatype, int dest, NBC_Schedule *schedule, bool barrier) { schedule 149 ompi/mca/coll/libnbc/nbc.c return NBC_Sched_send_internal (buf, tmpbuf, count, datatype, dest, true, schedule, barrier); schedule 153 ompi/mca/coll/libnbc/nbc.c static int NBC_Sched_recv_internal (void* buf, char tmpbuf, int count, MPI_Datatype datatype, int source, bool local, NBC_Schedule *schedule, bool barrier) { schedule 167 ompi/mca/coll/libnbc/nbc.c ret = nbc_schedule_round_append (schedule, &recv_args, sizeof (recv_args), barrier); schedule 172 ompi/mca/coll/libnbc/nbc.c NBC_DEBUG(10, "added receive - ends at byte %d\n", nbc_schedule_get_size (schedule)); schedule 177 ompi/mca/coll/libnbc/nbc.c int NBC_Sched_recv (void* buf, char tmpbuf, int count, MPI_Datatype datatype, int source, NBC_Schedule *schedule, bool barrier) { schedule 178 ompi/mca/coll/libnbc/nbc.c return NBC_Sched_recv_internal(buf, tmpbuf, count, datatype, source, false, schedule, barrier); schedule 181 ompi/mca/coll/libnbc/nbc.c int NBC_Sched_local_recv (void* buf, char tmpbuf, int count, MPI_Datatype datatype, int source, NBC_Schedule *schedule, bool barrier) { schedule 182 ompi/mca/coll/libnbc/nbc.c return NBC_Sched_recv_internal(buf, tmpbuf, count, datatype, source, true, schedule, barrier); schedule 187 ompi/mca/coll/libnbc/nbc.c MPI_Op op, NBC_Schedule *schedule, bool barrier) { schedule 202 ompi/mca/coll/libnbc/nbc.c ret = nbc_schedule_round_append (schedule, &op_args, sizeof (op_args), barrier); schedule 207 ompi/mca/coll/libnbc/nbc.c NBC_DEBUG(10, "added op2 - ends at byte %i\n", nbc_schedule_get_size (schedule)); schedule 214 ompi/mca/coll/libnbc/nbc.c MPI_Datatype tgttype, NBC_Schedule *schedule, bool barrier) { schedule 230 ompi/mca/coll/libnbc/nbc.c ret = nbc_schedule_round_append (schedule, ©_args, sizeof (copy_args), barrier); schedule 235 ompi/mca/coll/libnbc/nbc.c NBC_DEBUG(10, "added copy - ends at byte %i\n", nbc_schedule_get_size (schedule)); schedule 242 ompi/mca/coll/libnbc/nbc.c NBC_Schedule *schedule, bool barrier) { schedule 256 ompi/mca/coll/libnbc/nbc.c ret = nbc_schedule_round_append (schedule, &unpack_args, sizeof (unpack_args), barrier); schedule 261 ompi/mca/coll/libnbc/nbc.c NBC_DEBUG(10, "added unpack - ends at byte %i\n", nbc_schedule_get_size (schedule)); schedule 267 ompi/mca/coll/libnbc/nbc.c int NBC_Sched_barrier (NBC_Schedule *schedule) { schedule 268 ompi/mca/coll/libnbc/nbc.c return nbc_schedule_round_append (schedule, NULL, 0, true); schedule 272 ompi/mca/coll/libnbc/nbc.c int NBC_Sched_commit(NBC_Schedule *schedule) { schedule 273 ompi/mca/coll/libnbc/nbc.c int size = nbc_schedule_get_size (schedule); schedule 277 ompi/mca/coll/libnbc/nbc.c ret = nbc_schedule_grow (schedule, 1); schedule 283 ompi/mca/coll/libnbc/nbc.c ptr = schedule->data + size; schedule 287 ompi/mca/coll/libnbc/nbc.c nbc_schedule_inc_size (schedule, 1); schedule 289 ompi/mca/coll/libnbc/nbc.c NBC_DEBUG(10, "closed schedule %p at byte %i\n", schedule, (int)(size + 1)); schedule 299 ompi/mca/coll/libnbc/nbc.c if (NULL != handle->schedule) { schedule 301 ompi/mca/coll/libnbc/nbc.c OBJ_RELEASE (handle->schedule); schedule 302 ompi/mca/coll/libnbc/nbc.c handle->schedule = NULL; schedule 370 ompi/mca/coll/libnbc/nbc.c NBC_Error("NBC_Progress: an error %d was found during schedule %p at row-offset %li - aborting the schedule\n", res, handle->schedule, handle->row_offset); schedule 379 ompi/mca/coll/libnbc/nbc.c NBC_DEBUG(5, "NBC_Progress: going in schedule %p to row-offset: %li\n", handle->schedule, handle->row_offset); schedule 380 ompi/mca/coll/libnbc/nbc.c delim = handle->schedule->data + handle->row_offset; schedule 402 ompi/mca/coll/libnbc/nbc.c handle->row_offset = (intptr_t) (delim + 1) - (intptr_t) handle->schedule->data; schedule 428 ompi/mca/coll/libnbc/nbc.c ptr = handle->schedule->data + handle->row_offset; schedule 434 ompi/mca/coll/libnbc/nbc.c int offset = (intptr_t)(ptr - handle->schedule->data); schedule 672 ompi/mca/coll/libnbc/nbc.c int NBC_Schedule_request(NBC_Schedule *schedule, ompi_communicator_t *comm, schedule 680 ompi/mca/coll/libnbc/nbc.c if (((int *)schedule->data)[0] == 0 && schedule->data[sizeof(int)] == 0) { schedule 696 ompi/mca/coll/libnbc/nbc.c OBJ_RELEASE(schedule); schedule 709 ompi/mca/coll/libnbc/nbc.c handle->schedule = NULL; schedule 748 ompi/mca/coll/libnbc/nbc.c handle->schedule = schedule; schedule 762 ompi/mca/coll/libnbc/nbc.c OBJ_RELEASE(tmp->schedule); schedule 24 ompi/mca/coll/libnbc/nbc_iallgather.c int rank, int comm_size, NBC_Schedule *schedule, const void *sendbuf, schedule 28 ompi/mca/coll/libnbc/nbc_iallgather.c int rank, int comm_size, NBC_Schedule *schedule, const void *sbuf, schedule 58 ompi/mca/coll/libnbc/nbc_iallgather.c NBC_Schedule *schedule; schedule 116 ompi/mca/coll/libnbc/nbc_iallgather.c schedule = OBJ_NEW(NBC_Schedule); schedule 117 ompi/mca/coll/libnbc/nbc_iallgather.c if (OPAL_UNLIKELY(NULL == schedule)) { schedule 126 ompi/mca/coll/libnbc/nbc_iallgather.c rbuf, false, recvcount, recvtype, schedule, true); schedule 128 ompi/mca/coll/libnbc/nbc_iallgather.c OBJ_RELEASE(schedule); schedule 135 ompi/mca/coll/libnbc/nbc_iallgather.c res = allgather_sched_linear(rank, p, schedule, sendbuf, sendcount, sendtype, schedule 139 ompi/mca/coll/libnbc/nbc_iallgather.c res = allgather_sched_recursivedoubling(rank, p, schedule, sendbuf, sendcount, schedule 145 ompi/mca/coll/libnbc/nbc_iallgather.c OBJ_RELEASE(schedule); schedule 149 ompi/mca/coll/libnbc/nbc_iallgather.c res = NBC_Sched_commit(schedule); schedule 151 ompi/mca/coll/libnbc/nbc_iallgather.c OBJ_RELEASE(schedule); schedule 164 ompi/mca/coll/libnbc/nbc_iallgather.c args->schedule = schedule; schedule 170 ompi/mca/coll/libnbc/nbc_iallgather.c OBJ_RETAIN(schedule); schedule 179 ompi/mca/coll/libnbc/nbc_iallgather.c schedule = found->schedule; schedule 180 ompi/mca/coll/libnbc/nbc_iallgather.c OBJ_RETAIN(schedule); schedule 184 ompi/mca/coll/libnbc/nbc_iallgather.c res = NBC_Schedule_request(schedule, comm, libnbc_module, persistent, request, NULL); schedule 186 ompi/mca/coll/libnbc/nbc_iallgather.c OBJ_RELEASE(schedule); schedule 219 ompi/mca/coll/libnbc/nbc_iallgather.c NBC_Schedule *schedule; schedule 232 ompi/mca/coll/libnbc/nbc_iallgather.c schedule = OBJ_NEW(NBC_Schedule); schedule 233 ompi/mca/coll/libnbc/nbc_iallgather.c if (OPAL_UNLIKELY(NULL == schedule)) { schedule 241 ompi/mca/coll/libnbc/nbc_iallgather.c res = NBC_Sched_recv (rbuf, false, recvcount, recvtype, r, schedule, false); schedule 243 ompi/mca/coll/libnbc/nbc_iallgather.c OBJ_RELEASE(schedule); schedule 248 ompi/mca/coll/libnbc/nbc_iallgather.c res = NBC_Sched_send (sendbuf, false, sendcount, sendtype, r, schedule, false); schedule 250 ompi/mca/coll/libnbc/nbc_iallgather.c OBJ_RELEASE(schedule); schedule 255 ompi/mca/coll/libnbc/nbc_iallgather.c res = NBC_Sched_commit (schedule); schedule 257 ompi/mca/coll/libnbc/nbc_iallgather.c OBJ_RELEASE(schedule); schedule 261 ompi/mca/coll/libnbc/nbc_iallgather.c res = NBC_Schedule_request(schedule, comm, libnbc_module, persistent, request, NULL); schedule 263 ompi/mca/coll/libnbc/nbc_iallgather.c OBJ_RELEASE(schedule); schedule 298 ompi/mca/coll/libnbc/nbc_iallgather.c int rank, int comm_size, NBC_Schedule *schedule, const void *sendbuf, schedule 312 ompi/mca/coll/libnbc/nbc_iallgather.c res = NBC_Sched_recv(rbuf, false, rcount, rdtype, remote, schedule, false); schedule 316 ompi/mca/coll/libnbc/nbc_iallgather.c res = NBC_Sched_send(sbuf, false, rcount, rdtype, remote, schedule, false); schedule 356 ompi/mca/coll/libnbc/nbc_iallgather.c int rank, int comm_size, NBC_Schedule *schedule, const void *sbuf, schedule 380 ompi/mca/coll/libnbc/nbc_iallgather.c rdtype, remote, schedule, false); schedule 384 ompi/mca/coll/libnbc/nbc_iallgather.c rdtype, remote, schedule, true); schedule 43 ompi/mca/coll/libnbc/nbc_iallgatherv.c NBC_Schedule *schedule; schedule 70 ompi/mca/coll/libnbc/nbc_iallgatherv.c schedule = OBJ_NEW(NBC_Schedule); schedule 71 ompi/mca/coll/libnbc/nbc_iallgatherv.c if (NULL == schedule) { schedule 80 ompi/mca/coll/libnbc/nbc_iallgatherv.c sbuf, false, recvcounts[rank], recvtype, schedule, true); schedule 82 ompi/mca/coll/libnbc/nbc_iallgatherv.c OBJ_RELEASE(schedule); schedule 93 ompi/mca/coll/libnbc/nbc_iallgatherv.c res = NBC_Sched_recv (rbuf, false, recvcounts[rpeer], recvtype, rpeer, schedule, false); schedule 95 ompi/mca/coll/libnbc/nbc_iallgatherv.c OBJ_RELEASE(schedule); schedule 100 ompi/mca/coll/libnbc/nbc_iallgatherv.c res = NBC_Sched_send (sbuf, false, recvcounts[rank], recvtype, speer, schedule, false); schedule 102 ompi/mca/coll/libnbc/nbc_iallgatherv.c OBJ_RELEASE(schedule); schedule 107 ompi/mca/coll/libnbc/nbc_iallgatherv.c res = NBC_Sched_commit (schedule); schedule 109 ompi/mca/coll/libnbc/nbc_iallgatherv.c OBJ_RELEASE(schedule); schedule 113 ompi/mca/coll/libnbc/nbc_iallgatherv.c res = NBC_Schedule_request (schedule, comm, libnbc_module, persistent, request, NULL); schedule 115 ompi/mca/coll/libnbc/nbc_iallgatherv.c OBJ_RELEASE(schedule); schedule 147 ompi/mca/coll/libnbc/nbc_iallgatherv.c NBC_Schedule *schedule; schedule 158 ompi/mca/coll/libnbc/nbc_iallgatherv.c schedule = OBJ_NEW(NBC_Schedule); schedule 159 ompi/mca/coll/libnbc/nbc_iallgatherv.c if (NULL == schedule) { schedule 168 ompi/mca/coll/libnbc/nbc_iallgatherv.c res = NBC_Sched_recv (rbuf, false, recvcounts[r], recvtype, r, schedule, false); schedule 170 ompi/mca/coll/libnbc/nbc_iallgatherv.c OBJ_RELEASE(schedule); schedule 178 ompi/mca/coll/libnbc/nbc_iallgatherv.c res = NBC_Sched_send (sendbuf, false, sendcount, sendtype, r, schedule, false); schedule 180 ompi/mca/coll/libnbc/nbc_iallgatherv.c OBJ_RELEASE(schedule); schedule 186 ompi/mca/coll/libnbc/nbc_iallgatherv.c res = NBC_Sched_commit (schedule); schedule 188 ompi/mca/coll/libnbc/nbc_iallgatherv.c OBJ_RELEASE(schedule); schedule 192 ompi/mca/coll/libnbc/nbc_iallgatherv.c res = NBC_Schedule_request(schedule, comm, libnbc_module, persistent, request, NULL); schedule 194 ompi/mca/coll/libnbc/nbc_iallgatherv.c OBJ_RELEASE(schedule); schedule 30 ompi/mca/coll/libnbc/nbc_iallreduce.c void *recvbuf, MPI_Op op, char inplace, NBC_Schedule *schedule, void *tmpbuf); schedule 32 ompi/mca/coll/libnbc/nbc_iallreduce.c void *recvbuf, MPI_Op op, int size, int ext, NBC_Schedule *schedule, schedule 36 ompi/mca/coll/libnbc/nbc_iallreduce.c NBC_Schedule *schedule, void *tmpbuf); schedule 40 ompi/mca/coll/libnbc/nbc_iallreduce.c NBC_Schedule *schedule, void *tmpbuf, struct ompi_communicator_t *comm); schedule 67 ompi/mca/coll/libnbc/nbc_iallreduce.c NBC_Schedule *schedule; schedule 142 ompi/mca/coll/libnbc/nbc_iallreduce.c schedule = OBJ_NEW(NBC_Schedule); schedule 143 ompi/mca/coll/libnbc/nbc_iallreduce.c if (NULL == schedule) { schedule 150 ompi/mca/coll/libnbc/nbc_iallreduce.c recvbuf, false, count, datatype, schedule, false); schedule 154 ompi/mca/coll/libnbc/nbc_iallreduce.c res = allred_sched_diss(rank, p, count, datatype, gap, sendbuf, recvbuf, op, inplace, schedule, tmpbuf); schedule 157 ompi/mca/coll/libnbc/nbc_iallreduce.c res = allred_sched_redscat_allgather(rank, p, count, datatype, gap, sendbuf, recvbuf, op, inplace, schedule, tmpbuf, comm); schedule 160 ompi/mca/coll/libnbc/nbc_iallreduce.c res = allred_sched_ring(rank, p, count, datatype, sendbuf, recvbuf, op, size, ext, schedule, tmpbuf); schedule 166 ompi/mca/coll/libnbc/nbc_iallreduce.c OBJ_RELEASE(schedule); schedule 171 ompi/mca/coll/libnbc/nbc_iallreduce.c res = NBC_Sched_commit(schedule); schedule 173 ompi/mca/coll/libnbc/nbc_iallreduce.c OBJ_RELEASE(schedule); schedule 187 ompi/mca/coll/libnbc/nbc_iallreduce.c args->schedule = schedule; schedule 190 ompi/mca/coll/libnbc/nbc_iallreduce.c OBJ_RETAIN(schedule); schedule 204 ompi/mca/coll/libnbc/nbc_iallreduce.c schedule = found->schedule; schedule 205 ompi/mca/coll/libnbc/nbc_iallreduce.c OBJ_RETAIN(schedule); schedule 209 ompi/mca/coll/libnbc/nbc_iallreduce.c res = NBC_Schedule_request (schedule, comm, libnbc_module, persistent, request, tmpbuf); schedule 211 ompi/mca/coll/libnbc/nbc_iallreduce.c OBJ_RELEASE(schedule); schedule 245 ompi/mca/coll/libnbc/nbc_iallreduce.c NBC_Schedule *schedule; schedule 271 ompi/mca/coll/libnbc/nbc_iallreduce.c schedule = OBJ_NEW(NBC_Schedule); schedule 272 ompi/mca/coll/libnbc/nbc_iallreduce.c if (OPAL_UNLIKELY(NULL == schedule)) { schedule 278 ompi/mca/coll/libnbc/nbc_iallreduce.c ext, size, schedule, tmpbuf); schedule 280 ompi/mca/coll/libnbc/nbc_iallreduce.c OBJ_RELEASE(schedule); schedule 285 ompi/mca/coll/libnbc/nbc_iallreduce.c res = NBC_Sched_commit(schedule); schedule 287 ompi/mca/coll/libnbc/nbc_iallreduce.c OBJ_RELEASE(schedule); schedule 292 ompi/mca/coll/libnbc/nbc_iallreduce.c res = NBC_Schedule_request(schedule, comm, libnbc_module, persistent, request, tmpbuf); schedule 294 ompi/mca/coll/libnbc/nbc_iallreduce.c OBJ_RELEASE(schedule); schedule 357 ompi/mca/coll/libnbc/nbc_iallreduce.c MPI_Op op, char inplace, NBC_Schedule *schedule, void *tmpbuf) { schedule 379 ompi/mca/coll/libnbc/nbc_iallreduce.c schedule, true); schedule 393 ompi/mca/coll/libnbc/nbc_iallreduce.c res = NBC_Sched_recv (rbuf, tmprbuf, count, datatype, peer, schedule, true); schedule 401 ompi/mca/coll/libnbc/nbc_iallreduce.c res = NBC_Sched_op (sendbuf, false, rbuf, tmprbuf, count, datatype, op, schedule, true); schedule 405 ompi/mca/coll/libnbc/nbc_iallreduce.c res = NBC_Sched_op (lbuf, tmplbuf, rbuf, tmprbuf, count, datatype, op, schedule, true); schedule 420 ompi/mca/coll/libnbc/nbc_iallreduce.c res = NBC_Sched_send (sendbuf, false, count, datatype, peer, schedule, false); schedule 423 ompi/mca/coll/libnbc/nbc_iallreduce.c res = NBC_Sched_send (lbuf, tmplbuf, count, datatype, peer, schedule, false); schedule 444 ompi/mca/coll/libnbc/nbc_iallreduce.c res = NBC_Sched_recv (recvbuf, false, count, datatype, peer, schedule, false); schedule 451 ompi/mca/coll/libnbc/nbc_iallreduce.c res = NBC_Sched_barrier (schedule); schedule 462 ompi/mca/coll/libnbc/nbc_iallreduce.c res = NBC_Sched_send (recvbuf, false, count, datatype, peer, schedule, false); schedule 474 ompi/mca/coll/libnbc/nbc_iallreduce.c int size, int ext, NBC_Schedule *schedule, void *tmpbuf) { schedule 619 ompi/mca/coll/libnbc/nbc_iallreduce.c schedule, false); schedule 622 ompi/mca/coll/libnbc/nbc_iallreduce.c schedule, false); schedule 630 ompi/mca/coll/libnbc/nbc_iallreduce.c schedule, true); schedule 636 ompi/mca/coll/libnbc/nbc_iallreduce.c segsizes[relement], datatype, op, schedule, true); schedule 655 ompi/mca/coll/libnbc/nbc_iallreduce.c schedule, false); schedule 661 ompi/mca/coll/libnbc/nbc_iallreduce.c schedule, true); schedule 674 ompi/mca/coll/libnbc/nbc_iallreduce.c ptrdiff_t gap, MPI_Op op, int ext, int size, NBC_Schedule *schedule, void *tmpbuf) { schedule 682 ompi/mca/coll/libnbc/nbc_iallreduce.c res = NBC_Sched_send (sendbuf, false, count, datatype, 0, schedule, false); schedule 689 ompi/mca/coll/libnbc/nbc_iallreduce.c res = NBC_Sched_recv (recvbuf, false, count, datatype, 0, schedule, false); schedule 691 ompi/mca/coll/libnbc/nbc_iallreduce.c res = NBC_Sched_recv ((void *)(-gap), true, count, datatype, 0, schedule, false); schedule 701 ompi/mca/coll/libnbc/nbc_iallreduce.c res = NBC_Sched_barrier (schedule); schedule 721 ompi/mca/coll/libnbc/nbc_iallreduce.c res = NBC_Sched_recv (rbuf, tmprbuf, count, datatype, rpeer, schedule, true); schedule 726 ompi/mca/coll/libnbc/nbc_iallreduce.c res = NBC_Sched_op (lbuf, tmplbuf, rbuf, tmprbuf, count, datatype, op, schedule, true); schedule 736 ompi/mca/coll/libnbc/nbc_iallreduce.c res = NBC_Sched_recv ((void *)(-gap), true, count, datatype, 0, schedule, false); schedule 742 ompi/mca/coll/libnbc/nbc_iallreduce.c res = NBC_Sched_send (recvbuf, false, count, datatype, 0, schedule, true); schedule 749 ompi/mca/coll/libnbc/nbc_iallreduce.c res = NBC_Sched_send ((void *)(-gap), true, count, datatype, rpeer, schedule, false); schedule 816 ompi/mca/coll/libnbc/nbc_iallreduce.c NBC_Schedule *schedule, void *tmpbuf, struct ompi_communicator_t *comm) schedule 825 ompi/mca/coll/libnbc/nbc_iallreduce.c rbuf, false, count, datatype, schedule, true); schedule 859 ompi/mca/coll/libnbc/nbc_iallreduce.c schedule, false); schedule 862 ompi/mca/coll/libnbc/nbc_iallreduce.c false, count_rhalf, datatype, rank - 1, schedule, true); schedule 866 ompi/mca/coll/libnbc/nbc_iallreduce.c false, count_rhalf, datatype, op, schedule, true); schedule 870 ompi/mca/coll/libnbc/nbc_iallreduce.c false, count_rhalf, datatype, rank - 1, schedule, true); schedule 881 ompi/mca/coll/libnbc/nbc_iallreduce.c false, count_rhalf, datatype, rank + 1, schedule, false); schedule 884 ompi/mca/coll/libnbc/nbc_iallreduce.c schedule, true); schedule 887 ompi/mca/coll/libnbc/nbc_iallreduce.c datatype, op, schedule, true); schedule 891 ompi/mca/coll/libnbc/nbc_iallreduce.c false, count_rhalf, datatype, rank + 1, schedule, true); schedule 951 ompi/mca/coll/libnbc/nbc_iallreduce.c false, scount[step], datatype, dest, schedule, false); schedule 954 ompi/mca/coll/libnbc/nbc_iallreduce.c false, rcount[step], datatype, dest, schedule, true); schedule 959 ompi/mca/coll/libnbc/nbc_iallreduce.c false, rcount[step], datatype, op, schedule, true); schedule 990 ompi/mca/coll/libnbc/nbc_iallreduce.c false, rcount[step], datatype, dest, schedule, false); schedule 993 ompi/mca/coll/libnbc/nbc_iallreduce.c false, scount[step], datatype, dest, schedule, true); schedule 1004 ompi/mca/coll/libnbc/nbc_iallreduce.c res = NBC_Sched_recv(rbuf, false, count, datatype, rank - 1, schedule, false); schedule 1008 ompi/mca/coll/libnbc/nbc_iallreduce.c res = NBC_Sched_send(rbuf, false, count, datatype, rank + 1, schedule, false); schedule 24 ompi/mca/coll/libnbc/nbc_ialltoall.c static inline int a2a_sched_linear(int rank, int p, MPI_Aint sndext, MPI_Aint rcvext, NBC_Schedule *schedule, schedule 27 ompi/mca/coll/libnbc/nbc_ialltoall.c static inline int a2a_sched_pairwise(int rank, int p, MPI_Aint sndext, MPI_Aint rcvext, NBC_Schedule *schedule, schedule 30 ompi/mca/coll/libnbc/nbc_ialltoall.c static inline int a2a_sched_diss(int rank, int p, MPI_Aint sndext, MPI_Aint rcvext, NBC_Schedule* schedule, schedule 33 ompi/mca/coll/libnbc/nbc_ialltoall.c static inline int a2a_sched_inplace(int rank, int p, NBC_Schedule* schedule, void* buf, int count, schedule 64 ompi/mca/coll/libnbc/nbc_ialltoall.c NBC_Schedule *schedule; schedule 195 ompi/mca/coll/libnbc/nbc_ialltoall.c schedule = OBJ_NEW(NBC_Schedule); schedule 196 ompi/mca/coll/libnbc/nbc_ialltoall.c if (OPAL_UNLIKELY(NULL == schedule)) { schedule 206 ompi/mca/coll/libnbc/nbc_ialltoall.c rbuf, false, recvcount, recvtype, schedule, false); schedule 208 ompi/mca/coll/libnbc/nbc_ialltoall.c OBJ_RELEASE(schedule); schedule 216 ompi/mca/coll/libnbc/nbc_ialltoall.c res = a2a_sched_inplace(rank, p, schedule, recvbuf, recvcount, recvtype, rcvext, gap, comm); schedule 219 ompi/mca/coll/libnbc/nbc_ialltoall.c res = a2a_sched_linear(rank, p, sndext, rcvext, schedule, sendbuf, sendcount, sendtype, recvbuf, recvcount, recvtype, comm); schedule 222 ompi/mca/coll/libnbc/nbc_ialltoall.c res = a2a_sched_diss(rank, p, sndext, rcvext, schedule, sendbuf, sendcount, sendtype, recvbuf, recvcount, recvtype, comm, tmpbuf); schedule 225 ompi/mca/coll/libnbc/nbc_ialltoall.c res = a2a_sched_pairwise(rank, p, sndext, rcvext, schedule, sendbuf, sendcount, sendtype, recvbuf, recvcount, recvtype, comm); schedule 230 ompi/mca/coll/libnbc/nbc_ialltoall.c OBJ_RELEASE(schedule); schedule 235 ompi/mca/coll/libnbc/nbc_ialltoall.c res = NBC_Sched_commit(schedule); schedule 237 ompi/mca/coll/libnbc/nbc_ialltoall.c OBJ_RELEASE(schedule); schedule 252 ompi/mca/coll/libnbc/nbc_ialltoall.c args->schedule = schedule; schedule 255 ompi/mca/coll/libnbc/nbc_ialltoall.c OBJ_RETAIN(schedule); schedule 269 ompi/mca/coll/libnbc/nbc_ialltoall.c schedule = found->schedule; schedule 270 ompi/mca/coll/libnbc/nbc_ialltoall.c OBJ_RETAIN(schedule); schedule 274 ompi/mca/coll/libnbc/nbc_ialltoall.c res = NBC_Schedule_request(schedule, comm, libnbc_module, persistent, request, tmpbuf); schedule 276 ompi/mca/coll/libnbc/nbc_ialltoall.c OBJ_RELEASE(schedule); schedule 309 ompi/mca/coll/libnbc/nbc_ialltoall.c NBC_Schedule *schedule; schedule 327 ompi/mca/coll/libnbc/nbc_ialltoall.c schedule = OBJ_NEW(NBC_Schedule); schedule 328 ompi/mca/coll/libnbc/nbc_ialltoall.c if (OPAL_UNLIKELY(NULL == schedule)) { schedule 335 ompi/mca/coll/libnbc/nbc_ialltoall.c res = NBC_Sched_send (sbuf, false, sendcount, sendtype, i, schedule, false); schedule 342 ompi/mca/coll/libnbc/nbc_ialltoall.c res = NBC_Sched_recv (rbuf, false, recvcount, recvtype, i, schedule, false); schedule 349 ompi/mca/coll/libnbc/nbc_ialltoall.c OBJ_RELEASE(schedule); schedule 353 ompi/mca/coll/libnbc/nbc_ialltoall.c res = NBC_Sched_commit (schedule); schedule 355 ompi/mca/coll/libnbc/nbc_ialltoall.c OBJ_RELEASE(schedule); schedule 359 ompi/mca/coll/libnbc/nbc_ialltoall.c res = NBC_Schedule_request(schedule, comm, libnbc_module, persistent, request, NULL); schedule 361 ompi/mca/coll/libnbc/nbc_ialltoall.c OBJ_RELEASE(schedule); schedule 387 ompi/mca/coll/libnbc/nbc_ialltoall.c static inline int a2a_sched_pairwise(int rank, int p, MPI_Aint sndext, MPI_Aint rcvext, NBC_Schedule* schedule, schedule 401 ompi/mca/coll/libnbc/nbc_ialltoall.c res = NBC_Sched_recv (rbuf, false, recvcount, recvtype, rcvpeer, schedule, false); schedule 407 ompi/mca/coll/libnbc/nbc_ialltoall.c res = NBC_Sched_send (sbuf, false, sendcount, sendtype, sndpeer, schedule, true); schedule 416 ompi/mca/coll/libnbc/nbc_ialltoall.c static inline int a2a_sched_linear(int rank, int p, MPI_Aint sndext, MPI_Aint rcvext, NBC_Schedule* schedule, schedule 428 ompi/mca/coll/libnbc/nbc_ialltoall.c res = NBC_Sched_recv (rbuf, false, recvcount, recvtype, r, schedule, false); schedule 434 ompi/mca/coll/libnbc/nbc_ialltoall.c res = NBC_Sched_send (sbuf, false, sendcount, sendtype, r, schedule, false); schedule 443 ompi/mca/coll/libnbc/nbc_ialltoall.c static inline int a2a_sched_diss(int rank, int p, MPI_Aint sndext, MPI_Aint rcvext, NBC_Schedule* schedule, schedule 484 ompi/mca/coll/libnbc/nbc_ialltoall.c (intptr_t)tmpbuf, true, datasize, MPI_BYTE, schedule, false); schedule 496 ompi/mca/coll/libnbc/nbc_ialltoall.c res = NBC_Sched_recv (rtmpbuf - (intptr_t)tmpbuf, true, offset, MPI_BYTE, rpeer, schedule, false); schedule 501 ompi/mca/coll/libnbc/nbc_ialltoall.c res = NBC_Sched_send (stmpbuf - (intptr_t)tmpbuf, true, offset, MPI_BYTE, speer, schedule, true); schedule 513 ompi/mca/coll/libnbc/nbc_ialltoall.c (void *)(intptr_t)(i * datasize), true, datasize, MPI_BYTE, schedule, schedule 527 ompi/mca/coll/libnbc/nbc_ialltoall.c res = NBC_Sched_unpack ((void *)(intptr_t) (i * datasize), true, recvcount, recvtype, rbuf, false, schedule, schedule 537 ompi/mca/coll/libnbc/nbc_ialltoall.c static inline int a2a_sched_inplace(int rank, int p, NBC_Schedule* schedule, void* buf, int count, schedule 549 ompi/mca/coll/libnbc/nbc_ialltoall.c schedule, true); schedule 553 ompi/mca/coll/libnbc/nbc_ialltoall.c res = NBC_Sched_send (sbuf, false , count, type, speer, schedule, false); schedule 557 ompi/mca/coll/libnbc/nbc_ialltoall.c res = NBC_Sched_recv (rbuf, false , count, type, rpeer, schedule, true); schedule 562 ompi/mca/coll/libnbc/nbc_ialltoall.c res = NBC_Sched_send ((void *)(-gap), true, count, type, rpeer, schedule, false); schedule 566 ompi/mca/coll/libnbc/nbc_ialltoall.c res = NBC_Sched_recv (sbuf, false, count, type, speer, schedule, true); schedule 577 ompi/mca/coll/libnbc/nbc_ialltoall.c schedule, true); schedule 581 ompi/mca/coll/libnbc/nbc_ialltoall.c res = NBC_Sched_send ((void *)(-gap), true , count, type, peer, schedule, false); schedule 585 ompi/mca/coll/libnbc/nbc_ialltoall.c res = NBC_Sched_recv (tbuf, false , count, type, peer, schedule, true); schedule 23 ompi/mca/coll/libnbc/nbc_ialltoallv.c static inline int a2av_sched_linear(int rank, int p, NBC_Schedule *schedule, schedule 29 ompi/mca/coll/libnbc/nbc_ialltoallv.c static inline int a2av_sched_pairwise(int rank, int p, NBC_Schedule *schedule, schedule 35 ompi/mca/coll/libnbc/nbc_ialltoallv.c static inline int a2av_sched_inplace(int rank, int p, NBC_Schedule *schedule, schedule 51 ompi/mca/coll/libnbc/nbc_ialltoallv.c NBC_Schedule *schedule; schedule 94 ompi/mca/coll/libnbc/nbc_ialltoallv.c schedule = OBJ_NEW(NBC_Schedule); schedule 95 ompi/mca/coll/libnbc/nbc_ialltoallv.c if (OPAL_UNLIKELY(NULL == schedule)) { schedule 105 ompi/mca/coll/libnbc/nbc_ialltoallv.c rbuf, false, recvcounts[rank], recvtype, schedule, false); schedule 107 ompi/mca/coll/libnbc/nbc_ialltoallv.c OBJ_RELEASE(schedule); schedule 113 ompi/mca/coll/libnbc/nbc_ialltoallv.c res = a2av_sched_inplace(rank, p, schedule, recvbuf, recvcounts, schedule 116 ompi/mca/coll/libnbc/nbc_ialltoallv.c res = a2av_sched_linear(rank, p, schedule, schedule 121 ompi/mca/coll/libnbc/nbc_ialltoallv.c OBJ_RELEASE(schedule); schedule 126 ompi/mca/coll/libnbc/nbc_ialltoallv.c res = NBC_Sched_commit (schedule); schedule 128 ompi/mca/coll/libnbc/nbc_ialltoallv.c OBJ_RELEASE(schedule); schedule 133 ompi/mca/coll/libnbc/nbc_ialltoallv.c res = NBC_Schedule_request(schedule, comm, libnbc_module, persistent, request, tmpbuf); schedule 135 ompi/mca/coll/libnbc/nbc_ialltoallv.c OBJ_RELEASE(schedule); schedule 172 ompi/mca/coll/libnbc/nbc_ialltoallv.c NBC_Schedule *schedule; schedule 190 ompi/mca/coll/libnbc/nbc_ialltoallv.c schedule = OBJ_NEW(NBC_Schedule); schedule 191 ompi/mca/coll/libnbc/nbc_ialltoallv.c if (OPAL_UNLIKELY(NULL == schedule)) { schedule 199 ompi/mca/coll/libnbc/nbc_ialltoallv.c res = NBC_Sched_send (sbuf, false, sendcounts[i], sendtype, i, schedule, false); schedule 201 ompi/mca/coll/libnbc/nbc_ialltoallv.c OBJ_RELEASE(schedule); schedule 208 ompi/mca/coll/libnbc/nbc_ialltoallv.c res = NBC_Sched_recv (rbuf, false, recvcounts[i], recvtype, i, schedule, false); schedule 210 ompi/mca/coll/libnbc/nbc_ialltoallv.c OBJ_RELEASE(schedule); schedule 216 ompi/mca/coll/libnbc/nbc_ialltoallv.c res = NBC_Sched_commit(schedule); schedule 218 ompi/mca/coll/libnbc/nbc_ialltoallv.c OBJ_RELEASE(schedule); schedule 222 ompi/mca/coll/libnbc/nbc_ialltoallv.c res = NBC_Schedule_request(schedule, comm, libnbc_module, persistent, request, NULL); schedule 224 ompi/mca/coll/libnbc/nbc_ialltoallv.c OBJ_RELEASE(schedule); schedule 253 ompi/mca/coll/libnbc/nbc_ialltoallv.c static inline int a2av_sched_linear(int rank, int p, NBC_Schedule *schedule, schedule 268 ompi/mca/coll/libnbc/nbc_ialltoallv.c res = NBC_Sched_send(sbuf, false, sendcounts[i], sendtype, i, schedule, false); schedule 277 ompi/mca/coll/libnbc/nbc_ialltoallv.c res = NBC_Sched_recv(rbuf, false, recvcounts[i], recvtype, i, schedule, false); schedule 288 ompi/mca/coll/libnbc/nbc_ialltoallv.c static inline int a2av_sched_pairwise(int rank, int p, NBC_Schedule *schedule, schedule 302 ompi/mca/coll/libnbc/nbc_ialltoallv.c res = NBC_Sched_send(sbuf, false, sendcounts[sndpeer], sendtype, sndpeer, schedule, false); schedule 311 ompi/mca/coll/libnbc/nbc_ialltoallv.c res = NBC_Sched_recv(rbuf, false, recvcounts[rcvpeer], recvtype, rcvpeer, schedule, true); schedule 321 ompi/mca/coll/libnbc/nbc_ialltoallv.c static inline int a2av_sched_inplace(int rank, int p, NBC_Schedule *schedule, schedule 335 ompi/mca/coll/libnbc/nbc_ialltoallv.c schedule, true); schedule 341 ompi/mca/coll/libnbc/nbc_ialltoallv.c res = NBC_Sched_send (sbuf, false , counts[speer], type, speer, schedule, false); schedule 347 ompi/mca/coll/libnbc/nbc_ialltoallv.c res = NBC_Sched_recv (rbuf, false , counts[rpeer], type, rpeer, schedule, true); schedule 354 ompi/mca/coll/libnbc/nbc_ialltoallv.c res = NBC_Sched_send ((void *)(-gap), true, counts[rpeer], type, rpeer, schedule, false); schedule 360 ompi/mca/coll/libnbc/nbc_ialltoallv.c res = NBC_Sched_recv (sbuf, false, counts[speer], type, speer, schedule, true); schedule 372 ompi/mca/coll/libnbc/nbc_ialltoallv.c schedule, true); schedule 377 ompi/mca/coll/libnbc/nbc_ialltoallv.c res = NBC_Sched_send ((void *)(-gap), true , counts[peer], type, peer, schedule, false); schedule 381 ompi/mca/coll/libnbc/nbc_ialltoallv.c res = NBC_Sched_recv (tbuf, false , counts[peer], type, peer, schedule, true); schedule 23 ompi/mca/coll/libnbc/nbc_ialltoallw.c static inline int a2aw_sched_linear(int rank, int p, NBC_Schedule *schedule, schedule 29 ompi/mca/coll/libnbc/nbc_ialltoallw.c static inline int a2aw_sched_pairwise(int rank, int p, NBC_Schedule *schedule, schedule 35 ompi/mca/coll/libnbc/nbc_ialltoallw.c static inline int a2aw_sched_inplace(int rank, int p, NBC_Schedule *schedule, schedule 50 ompi/mca/coll/libnbc/nbc_ialltoallw.c NBC_Schedule *schedule; schedule 82 ompi/mca/coll/libnbc/nbc_ialltoallw.c schedule = OBJ_NEW(NBC_Schedule); schedule 83 ompi/mca/coll/libnbc/nbc_ialltoallw.c if (OPAL_UNLIKELY(NULL == schedule)) { schedule 92 ompi/mca/coll/libnbc/nbc_ialltoallw.c rbuf, false, recvcounts[rank], recvtypes[rank], schedule, false); schedule 99 ompi/mca/coll/libnbc/nbc_ialltoallw.c res = a2aw_sched_inplace(rank, p, schedule, recvbuf, schedule 102 ompi/mca/coll/libnbc/nbc_ialltoallw.c res = a2aw_sched_linear(rank, p, schedule, schedule 107 ompi/mca/coll/libnbc/nbc_ialltoallw.c OBJ_RELEASE(schedule); schedule 112 ompi/mca/coll/libnbc/nbc_ialltoallw.c res = NBC_Sched_commit (schedule); schedule 114 ompi/mca/coll/libnbc/nbc_ialltoallw.c OBJ_RELEASE(schedule); schedule 119 ompi/mca/coll/libnbc/nbc_ialltoallw.c res = NBC_Schedule_request(schedule, comm, libnbc_module, persistent, request, tmpbuf); schedule 121 ompi/mca/coll/libnbc/nbc_ialltoallw.c OBJ_RELEASE(schedule); schedule 157 ompi/mca/coll/libnbc/nbc_ialltoallw.c NBC_Schedule *schedule; schedule 163 ompi/mca/coll/libnbc/nbc_ialltoallw.c schedule = OBJ_NEW(NBC_Schedule); schedule 164 ompi/mca/coll/libnbc/nbc_ialltoallw.c if (OPAL_UNLIKELY(NULL == schedule)) { schedule 172 ompi/mca/coll/libnbc/nbc_ialltoallw.c res = NBC_Sched_send (sbuf, false, sendcounts[i], sendtypes[i], i, schedule, false); schedule 174 ompi/mca/coll/libnbc/nbc_ialltoallw.c OBJ_RELEASE(schedule); schedule 181 ompi/mca/coll/libnbc/nbc_ialltoallw.c res = NBC_Sched_recv (rbuf, false, recvcounts[i], recvtypes[i], i, schedule, false); schedule 183 ompi/mca/coll/libnbc/nbc_ialltoallw.c OBJ_RELEASE(schedule); schedule 189 ompi/mca/coll/libnbc/nbc_ialltoallw.c res = NBC_Sched_commit (schedule); schedule 191 ompi/mca/coll/libnbc/nbc_ialltoallw.c OBJ_RELEASE(schedule); schedule 195 ompi/mca/coll/libnbc/nbc_ialltoallw.c res = NBC_Schedule_request(schedule, comm, libnbc_module, persistent, request, NULL); schedule 197 ompi/mca/coll/libnbc/nbc_ialltoallw.c OBJ_RELEASE(schedule); schedule 225 ompi/mca/coll/libnbc/nbc_ialltoallw.c static inline int a2aw_sched_linear(int rank, int p, NBC_Schedule *schedule, schedule 242 ompi/mca/coll/libnbc/nbc_ialltoallw.c res = NBC_Sched_send (sbuf, false, sendcounts[i], sendtypes[i], i, schedule, false); schedule 251 ompi/mca/coll/libnbc/nbc_ialltoallw.c res = NBC_Sched_recv (rbuf, false, recvcounts[i], recvtypes[i], i, schedule, false); schedule 262 ompi/mca/coll/libnbc/nbc_ialltoallw.c static inline int a2aw_sched_pairwise(int rank, int p, NBC_Schedule *schedule, schedule 276 ompi/mca/coll/libnbc/nbc_ialltoallw.c res = NBC_Sched_send (sbuf, false, sendcounts[sndpeer], sendtypes[sndpeer], sndpeer, schedule, false); schedule 284 ompi/mca/coll/libnbc/nbc_ialltoallw.c res = NBC_Sched_recv (rbuf, false, recvcounts[rcvpeer], recvtypes[rcvpeer], rcvpeer, schedule, true); schedule 294 ompi/mca/coll/libnbc/nbc_ialltoallw.c static inline int a2aw_sched_inplace(int rank, int p, NBC_Schedule *schedule, schedule 310 ompi/mca/coll/libnbc/nbc_ialltoallw.c schedule, true); schedule 316 ompi/mca/coll/libnbc/nbc_ialltoallw.c res = NBC_Sched_send (sbuf, false , counts[speer], types[speer], speer, schedule, false); schedule 322 ompi/mca/coll/libnbc/nbc_ialltoallw.c res = NBC_Sched_recv (rbuf, false , counts[rpeer], types[rpeer], rpeer, schedule, true); schedule 329 ompi/mca/coll/libnbc/nbc_ialltoallw.c res = NBC_Sched_send ((void *)(-gap), true, counts[rpeer], types[rpeer], rpeer, schedule, false); schedule 335 ompi/mca/coll/libnbc/nbc_ialltoallw.c res = NBC_Sched_recv (sbuf, false, counts[speer], types[speer], speer, schedule, true); schedule 348 ompi/mca/coll/libnbc/nbc_ialltoallw.c schedule, true); schedule 352 ompi/mca/coll/libnbc/nbc_ialltoallw.c res = NBC_Sched_send ((void *)(-gap), true , counts[peer], types[peer], peer, schedule, false); schedule 356 ompi/mca/coll/libnbc/nbc_ialltoallw.c res = NBC_Sched_recv (tbuf, false , counts[peer], types[peer], peer, schedule, true); schedule 29 ompi/mca/coll/libnbc/nbc_ibarrier.c NBC_Schedule *schedule; schedule 43 ompi/mca/coll/libnbc/nbc_ibarrier.c schedule = OBJ_NEW(NBC_Schedule); schedule 44 ompi/mca/coll/libnbc/nbc_ibarrier.c if (OPAL_UNLIKELY(NULL == schedule)) { schedule 56 ompi/mca/coll/libnbc/nbc_ibarrier.c res = NBC_Sched_send (NULL, false, 0, MPI_BYTE, sendpeer, schedule, false); schedule 58 ompi/mca/coll/libnbc/nbc_ibarrier.c OBJ_RELEASE(schedule); schedule 63 ompi/mca/coll/libnbc/nbc_ibarrier.c res = NBC_Sched_recv (NULL, false, 0, MPI_BYTE, recvpeer, schedule, false); schedule 65 ompi/mca/coll/libnbc/nbc_ibarrier.c OBJ_RELEASE(schedule); schedule 71 ompi/mca/coll/libnbc/nbc_ibarrier.c res = NBC_Sched_barrier (schedule); schedule 73 ompi/mca/coll/libnbc/nbc_ibarrier.c OBJ_RELEASE(schedule); schedule 79 ompi/mca/coll/libnbc/nbc_ibarrier.c res = NBC_Sched_commit (schedule); schedule 81 ompi/mca/coll/libnbc/nbc_ibarrier.c OBJ_RELEASE(schedule); schedule 87 ompi/mca/coll/libnbc/nbc_ibarrier.c libnbc_module->NBC_Dict[NBC_BARRIER] = (hb_tree *) schedule; schedule 90 ompi/mca/coll/libnbc/nbc_ibarrier.c OBJ_RETAIN(schedule); schedule 93 ompi/mca/coll/libnbc/nbc_ibarrier.c res = NBC_Schedule_request(schedule, comm, libnbc_module, persistent, request, NULL); schedule 95 ompi/mca/coll/libnbc/nbc_ibarrier.c OBJ_RELEASE(schedule); schedule 123 ompi/mca/coll/libnbc/nbc_ibarrier.c NBC_Schedule *schedule; schedule 129 ompi/mca/coll/libnbc/nbc_ibarrier.c schedule = OBJ_NEW(NBC_Schedule); schedule 130 ompi/mca/coll/libnbc/nbc_ibarrier.c if (OPAL_UNLIKELY(NULL == schedule)) { schedule 136 ompi/mca/coll/libnbc/nbc_ibarrier.c res = NBC_Sched_recv (NULL, false, 0, MPI_BYTE, peer, schedule, false); schedule 138 ompi/mca/coll/libnbc/nbc_ibarrier.c OBJ_RELEASE(schedule); schedule 145 ompi/mca/coll/libnbc/nbc_ibarrier.c res = NBC_Sched_recv (NULL, false, 0, MPI_BYTE, 0, schedule, false); schedule 147 ompi/mca/coll/libnbc/nbc_ibarrier.c OBJ_RELEASE(schedule); schedule 151 ompi/mca/coll/libnbc/nbc_ibarrier.c res = NBC_Sched_send (NULL, false, 0, MPI_BYTE, 0, schedule, false); schedule 153 ompi/mca/coll/libnbc/nbc_ibarrier.c OBJ_RELEASE(schedule); schedule 159 ompi/mca/coll/libnbc/nbc_ibarrier.c res = NBC_Sched_barrier (schedule); schedule 161 ompi/mca/coll/libnbc/nbc_ibarrier.c OBJ_RELEASE(schedule); schedule 167 ompi/mca/coll/libnbc/nbc_ibarrier.c res = NBC_Sched_send (NULL, false, 0, MPI_BYTE, peer, schedule, false); schedule 169 ompi/mca/coll/libnbc/nbc_ibarrier.c OBJ_RELEASE(schedule); schedule 175 ompi/mca/coll/libnbc/nbc_ibarrier.c res = NBC_Sched_commit (schedule); schedule 177 ompi/mca/coll/libnbc/nbc_ibarrier.c OBJ_RELEASE(schedule); schedule 181 ompi/mca/coll/libnbc/nbc_ibarrier.c res = NBC_Schedule_request(schedule, comm, libnbc_module, persistent, request, NULL); schedule 183 ompi/mca/coll/libnbc/nbc_ibarrier.c OBJ_RELEASE(schedule); schedule 23 ompi/mca/coll/libnbc/nbc_ibcast.c static inline int bcast_sched_binomial(int rank, int p, int root, NBC_Schedule *schedule, void *buffer, int count, schedule 25 ompi/mca/coll/libnbc/nbc_ibcast.c static inline int bcast_sched_linear(int rank, int p, int root, NBC_Schedule *schedule, void *buffer, int count, schedule 27 ompi/mca/coll/libnbc/nbc_ibcast.c static inline int bcast_sched_chain(int rank, int p, int root, NBC_Schedule *schedule, void *buffer, int count, schedule 29 ompi/mca/coll/libnbc/nbc_ibcast.c static inline int bcast_sched_knomial(int rank, int comm_size, int root, NBC_Schedule *schedule, void *buf, schedule 56 ompi/mca/coll/libnbc/nbc_ibcast.c NBC_Schedule *schedule; schedule 124 ompi/mca/coll/libnbc/nbc_ibcast.c schedule = OBJ_NEW(NBC_Schedule); schedule 125 ompi/mca/coll/libnbc/nbc_ibcast.c if (OPAL_UNLIKELY(NULL == schedule)) { schedule 131 ompi/mca/coll/libnbc/nbc_ibcast.c res = bcast_sched_linear(rank, p, root, schedule, buffer, count, datatype); schedule 134 ompi/mca/coll/libnbc/nbc_ibcast.c res = bcast_sched_binomial(rank, p, root, schedule, buffer, count, datatype); schedule 137 ompi/mca/coll/libnbc/nbc_ibcast.c res = bcast_sched_chain(rank, p, root, schedule, buffer, count, datatype, segsize, size); schedule 140 ompi/mca/coll/libnbc/nbc_ibcast.c res = bcast_sched_knomial(rank, p, root, schedule, buffer, count, datatype, libnbc_ibcast_knomial_radix); schedule 145 ompi/mca/coll/libnbc/nbc_ibcast.c OBJ_RELEASE(schedule); schedule 149 ompi/mca/coll/libnbc/nbc_ibcast.c res = NBC_Sched_commit (schedule); schedule 151 ompi/mca/coll/libnbc/nbc_ibcast.c OBJ_RELEASE(schedule); schedule 163 ompi/mca/coll/libnbc/nbc_ibcast.c args->schedule = schedule; schedule 166 ompi/mca/coll/libnbc/nbc_ibcast.c OBJ_RETAIN (schedule); schedule 180 ompi/mca/coll/libnbc/nbc_ibcast.c schedule = found->schedule; schedule 181 ompi/mca/coll/libnbc/nbc_ibcast.c OBJ_RETAIN(schedule); schedule 185 ompi/mca/coll/libnbc/nbc_ibcast.c res = NBC_Schedule_request(schedule, comm, libnbc_module, persistent, request, NULL); schedule 187 ompi/mca/coll/libnbc/nbc_ibcast.c OBJ_RELEASE(schedule); schedule 238 ompi/mca/coll/libnbc/nbc_ibcast.c static inline int bcast_sched_binomial(int rank, int p, int root, NBC_Schedule *schedule, void *buffer, int count, MPI_Datatype datatype) { schedule 250 ompi/mca/coll/libnbc/nbc_ibcast.c res = NBC_Sched_recv (buffer, false, count, datatype, peer, schedule, false); schedule 257 ompi/mca/coll/libnbc/nbc_ibcast.c res = NBC_Sched_barrier (schedule); schedule 267 ompi/mca/coll/libnbc/nbc_ibcast.c res = NBC_Sched_send (buffer, false, count, datatype, peer, schedule, false); schedule 278 ompi/mca/coll/libnbc/nbc_ibcast.c static inline int bcast_sched_linear(int rank, int p, int root, NBC_Schedule *schedule, void *buffer, int count, MPI_Datatype datatype) { schedule 286 ompi/mca/coll/libnbc/nbc_ibcast.c res = NBC_Sched_send (buffer, false, count, datatype, peer, schedule, false); schedule 294 ompi/mca/coll/libnbc/nbc_ibcast.c res = NBC_Sched_recv (buffer, false, count, datatype, root, schedule, false); schedule 304 ompi/mca/coll/libnbc/nbc_ibcast.c static inline int bcast_sched_chain(int rank, int p, int root, NBC_Schedule *schedule, void *buffer, int count, MPI_Datatype datatype, int fragsize, size_t size) { schedule 339 ompi/mca/coll/libnbc/nbc_ibcast.c res = NBC_Sched_recv (buf, false, thiscount, datatype, rpeer, schedule, true); schedule 347 ompi/mca/coll/libnbc/nbc_ibcast.c res = NBC_Sched_send (buf, false, thiscount, datatype, speer, schedule, false); schedule 354 ompi/mca/coll/libnbc/nbc_ibcast.c res = NBC_Sched_barrier (schedule); schedule 374 ompi/mca/coll/libnbc/nbc_ibcast.c int rank, int comm_size, int root, NBC_Schedule *schedule, void *buf, schedule 386 ompi/mca/coll/libnbc/nbc_ibcast.c res = NBC_Sched_recv(buf, false, count, datatype, parent, schedule, true); schedule 400 ompi/mca/coll/libnbc/nbc_ibcast.c res = NBC_Sched_send(buf, false, count, datatype, child, schedule, false); schedule 415 ompi/mca/coll/libnbc/nbc_ibcast.c NBC_Schedule *schedule; schedule 418 ompi/mca/coll/libnbc/nbc_ibcast.c schedule = OBJ_NEW(NBC_Schedule); schedule 419 ompi/mca/coll/libnbc/nbc_ibcast.c if (OPAL_UNLIKELY(NULL == schedule)) { schedule 432 ompi/mca/coll/libnbc/nbc_ibcast.c res = NBC_Sched_send (buffer, false, count, datatype, peer, schedule, false); schedule 434 ompi/mca/coll/libnbc/nbc_ibcast.c OBJ_RELEASE(schedule); schedule 440 ompi/mca/coll/libnbc/nbc_ibcast.c res = NBC_Sched_recv (buffer, false, count, datatype, root, schedule, false); schedule 442 ompi/mca/coll/libnbc/nbc_ibcast.c OBJ_RELEASE(schedule); schedule 448 ompi/mca/coll/libnbc/nbc_ibcast.c res = NBC_Sched_commit (schedule); schedule 450 ompi/mca/coll/libnbc/nbc_ibcast.c OBJ_RELEASE(schedule); schedule 454 ompi/mca/coll/libnbc/nbc_ibcast.c res = NBC_Schedule_request(schedule, comm, libnbc_module, persistent, request, NULL); schedule 456 ompi/mca/coll/libnbc/nbc_ibcast.c OBJ_RELEASE(schedule); schedule 28 ompi/mca/coll/libnbc/nbc_iexscan.c MPI_Datatype datatype, MPI_Op op, char inplace, NBC_Schedule *schedule, schedule 33 ompi/mca/coll/libnbc/nbc_iexscan.c NBC_Schedule *schedule, void *tmpbuf1, void *tmpbuf2); schedule 58 ompi/mca/coll/libnbc/nbc_iexscan.c NBC_Schedule *schedule; schedule 101 ompi/mca/coll/libnbc/nbc_iexscan.c schedule = OBJ_NEW(NBC_Schedule); schedule 102 ompi/mca/coll/libnbc/nbc_iexscan.c if (OPAL_UNLIKELY(NULL == schedule)) { schedule 109 ompi/mca/coll/libnbc/nbc_iexscan.c op, inplace, schedule, tmpbuf); schedule 112 ompi/mca/coll/libnbc/nbc_iexscan.c datatype, op, inplace, schedule, tmpbuf1, tmpbuf2); schedule 115 ompi/mca/coll/libnbc/nbc_iexscan.c OBJ_RELEASE(schedule); schedule 120 ompi/mca/coll/libnbc/nbc_iexscan.c res = NBC_Sched_commit(schedule); schedule 122 ompi/mca/coll/libnbc/nbc_iexscan.c OBJ_RELEASE(schedule); schedule 136 ompi/mca/coll/libnbc/nbc_iexscan.c args->schedule = schedule; schedule 139 ompi/mca/coll/libnbc/nbc_iexscan.c OBJ_RETAIN(schedule); schedule 153 ompi/mca/coll/libnbc/nbc_iexscan.c schedule = found->schedule; schedule 154 ompi/mca/coll/libnbc/nbc_iexscan.c OBJ_RETAIN(schedule); schedule 158 ompi/mca/coll/libnbc/nbc_iexscan.c res = NBC_Schedule_request(schedule, comm, libnbc_module, persistent, request, tmpbuf); schedule 160 ompi/mca/coll/libnbc/nbc_iexscan.c OBJ_RELEASE(schedule); schedule 215 ompi/mca/coll/libnbc/nbc_iexscan.c MPI_Datatype datatype, MPI_Op op, char inplace, NBC_Schedule *schedule, schedule 225 ompi/mca/coll/libnbc/nbc_iexscan.c (char *)tmpbuf - gap, false, count, datatype, schedule, false); schedule 228 ompi/mca/coll/libnbc/nbc_iexscan.c (char *)tmpbuf - gap, false, count, datatype, schedule, false); schedule 232 ompi/mca/coll/libnbc/nbc_iexscan.c res = NBC_Sched_recv(recvbuf, false, count, datatype, rank - 1, schedule, false); schedule 237 ompi/mca/coll/libnbc/nbc_iexscan.c res = NBC_Sched_barrier(schedule); schedule 241 ompi/mca/coll/libnbc/nbc_iexscan.c datatype, op, schedule, true); schedule 245 ompi/mca/coll/libnbc/nbc_iexscan.c res = NBC_Sched_send ((void *)(-gap), true, count, datatype, rank + 1, schedule, false); schedule 251 ompi/mca/coll/libnbc/nbc_iexscan.c res = NBC_Sched_send(recvbuf, false, count, datatype, 1, schedule, false); schedule 253 ompi/mca/coll/libnbc/nbc_iexscan.c res = NBC_Sched_send(sendbuf, false, count, datatype, 1, schedule, false); schedule 298 ompi/mca/coll/libnbc/nbc_iexscan.c NBC_Schedule *schedule, void *tmpbuf1, void *tmpbuf2) schedule 306 ompi/mca/coll/libnbc/nbc_iexscan.c psend, true, count, datatype, schedule, true); schedule 309 ompi/mca/coll/libnbc/nbc_iexscan.c psend, true, count, datatype, schedule, true); schedule 319 ompi/mca/coll/libnbc/nbc_iexscan.c res = NBC_Sched_send(psend, true, count, datatype, remote, schedule, false); schedule 321 ompi/mca/coll/libnbc/nbc_iexscan.c res = NBC_Sched_recv(precv, true, count, datatype, remote, schedule, true); schedule 328 ompi/mca/coll/libnbc/nbc_iexscan.c recvbuf, false, count, datatype, schedule, false); schedule 334 ompi/mca/coll/libnbc/nbc_iexscan.c datatype, op, schedule, false); schedule 339 ompi/mca/coll/libnbc/nbc_iexscan.c datatype, op, schedule, true); schedule 345 ompi/mca/coll/libnbc/nbc_iexscan.c datatype, op, schedule, true); schedule 350 ompi/mca/coll/libnbc/nbc_iexscan.c datatype, op, schedule, true); schedule 53 ompi/mca/coll/libnbc/nbc_igather.c NBC_Schedule *schedule; schedule 91 ompi/mca/coll/libnbc/nbc_igather.c schedule = OBJ_NEW(NBC_Schedule); schedule 92 ompi/mca/coll/libnbc/nbc_igather.c if (OPAL_UNLIKELY(NULL == schedule)) { schedule 99 ompi/mca/coll/libnbc/nbc_igather.c res = NBC_Sched_send(sendbuf, false, sendcount, sendtype, root, schedule, false); schedule 101 ompi/mca/coll/libnbc/nbc_igather.c OBJ_RELEASE(schedule); schedule 111 ompi/mca/coll/libnbc/nbc_igather.c rbuf, false, recvcount, recvtype, schedule, false); schedule 113 ompi/mca/coll/libnbc/nbc_igather.c OBJ_RELEASE(schedule); schedule 119 ompi/mca/coll/libnbc/nbc_igather.c res = NBC_Sched_recv (rbuf, false, recvcount, recvtype, i, schedule, false); schedule 121 ompi/mca/coll/libnbc/nbc_igather.c OBJ_RELEASE(schedule); schedule 128 ompi/mca/coll/libnbc/nbc_igather.c res = NBC_Sched_commit (schedule); schedule 130 ompi/mca/coll/libnbc/nbc_igather.c OBJ_RELEASE(schedule); schedule 145 ompi/mca/coll/libnbc/nbc_igather.c args->schedule = schedule; schedule 148 ompi/mca/coll/libnbc/nbc_igather.c OBJ_RETAIN(schedule); schedule 162 ompi/mca/coll/libnbc/nbc_igather.c schedule = found->schedule; schedule 163 ompi/mca/coll/libnbc/nbc_igather.c OBJ_RETAIN(schedule); schedule 167 ompi/mca/coll/libnbc/nbc_igather.c res = NBC_Schedule_request(schedule, comm, libnbc_module, persistent, request, NULL); schedule 169 ompi/mca/coll/libnbc/nbc_igather.c OBJ_RELEASE(schedule); schedule 202 ompi/mca/coll/libnbc/nbc_igather.c NBC_Schedule *schedule; schedule 216 ompi/mca/coll/libnbc/nbc_igather.c schedule = OBJ_NEW(NBC_Schedule); schedule 217 ompi/mca/coll/libnbc/nbc_igather.c if (OPAL_UNLIKELY(NULL == schedule)) { schedule 224 ompi/mca/coll/libnbc/nbc_igather.c res = NBC_Sched_send (sendbuf, false, sendcount, sendtype, root, schedule, false); schedule 226 ompi/mca/coll/libnbc/nbc_igather.c OBJ_RELEASE(schedule); schedule 233 ompi/mca/coll/libnbc/nbc_igather.c res = NBC_Sched_recv (rbuf, false, recvcount, recvtype, i, schedule, false); schedule 235 ompi/mca/coll/libnbc/nbc_igather.c OBJ_RELEASE(schedule); schedule 241 ompi/mca/coll/libnbc/nbc_igather.c res = NBC_Sched_commit (schedule); schedule 243 ompi/mca/coll/libnbc/nbc_igather.c OBJ_RELEASE(schedule); schedule 247 ompi/mca/coll/libnbc/nbc_igather.c res = NBC_Schedule_request(schedule, comm, libnbc_module, persistent, request, NULL); schedule 249 ompi/mca/coll/libnbc/nbc_igather.c OBJ_RELEASE(schedule); schedule 38 ompi/mca/coll/libnbc/nbc_igatherv.c NBC_Schedule *schedule; schedule 56 ompi/mca/coll/libnbc/nbc_igatherv.c schedule = OBJ_NEW(NBC_Schedule); schedule 57 ompi/mca/coll/libnbc/nbc_igatherv.c if (OPAL_UNLIKELY(NULL == schedule)) { schedule 64 ompi/mca/coll/libnbc/nbc_igatherv.c res = NBC_Sched_send (sendbuf, false, sendcount, sendtype, root, schedule, false); schedule 66 ompi/mca/coll/libnbc/nbc_igatherv.c OBJ_RELEASE(schedule); schedule 76 ompi/mca/coll/libnbc/nbc_igatherv.c rbuf, false, recvcounts[i], recvtype, schedule, false); schedule 78 ompi/mca/coll/libnbc/nbc_igatherv.c OBJ_RELEASE(schedule); schedule 84 ompi/mca/coll/libnbc/nbc_igatherv.c res = NBC_Sched_recv (rbuf, false, recvcounts[i], recvtype, i, schedule, false); schedule 86 ompi/mca/coll/libnbc/nbc_igatherv.c OBJ_RELEASE(schedule); schedule 93 ompi/mca/coll/libnbc/nbc_igatherv.c res = NBC_Sched_commit (schedule); schedule 95 ompi/mca/coll/libnbc/nbc_igatherv.c OBJ_RELEASE(schedule); schedule 99 ompi/mca/coll/libnbc/nbc_igatherv.c res = NBC_Schedule_request(schedule, comm, libnbc_module, persistent, request, NULL); schedule 101 ompi/mca/coll/libnbc/nbc_igatherv.c OBJ_RELEASE(schedule); schedule 134 ompi/mca/coll/libnbc/nbc_igatherv.c NBC_Schedule *schedule; schedule 148 ompi/mca/coll/libnbc/nbc_igatherv.c schedule = OBJ_NEW(NBC_Schedule); schedule 149 ompi/mca/coll/libnbc/nbc_igatherv.c if (OPAL_UNLIKELY(NULL == schedule)) { schedule 156 ompi/mca/coll/libnbc/nbc_igatherv.c res = NBC_Sched_send (sendbuf, false, sendcount, sendtype, root, schedule, false); schedule 158 ompi/mca/coll/libnbc/nbc_igatherv.c OBJ_RELEASE(schedule); schedule 165 ompi/mca/coll/libnbc/nbc_igatherv.c res = NBC_Sched_recv (rbuf, false, recvcounts[i], recvtype, i, schedule, false); schedule 167 ompi/mca/coll/libnbc/nbc_igatherv.c OBJ_RELEASE(schedule); schedule 173 ompi/mca/coll/libnbc/nbc_igatherv.c res = NBC_Sched_commit (schedule); schedule 175 ompi/mca/coll/libnbc/nbc_igatherv.c OBJ_RELEASE(schedule); schedule 179 ompi/mca/coll/libnbc/nbc_igatherv.c res = NBC_Schedule_request(schedule, comm, libnbc_module, persistent, request, NULL); schedule 181 ompi/mca/coll/libnbc/nbc_igatherv.c OBJ_RELEASE(schedule); schedule 54 ompi/mca/coll/libnbc/nbc_ineighbor_allgather.c NBC_Schedule *schedule; schedule 76 ompi/mca/coll/libnbc/nbc_ineighbor_allgather.c schedule = OBJ_NEW(NBC_Schedule); schedule 77 ompi/mca/coll/libnbc/nbc_ineighbor_allgather.c if (OPAL_UNLIKELY(NULL == schedule)) { schedule 83 ompi/mca/coll/libnbc/nbc_ineighbor_allgather.c OBJ_RELEASE(schedule); schedule 89 ompi/mca/coll/libnbc/nbc_ineighbor_allgather.c res = NBC_Sched_recv ((char *) rbuf + i * rcount * rcvext, true, rcount, rtype, srcs[i], schedule, false); schedule 99 ompi/mca/coll/libnbc/nbc_ineighbor_allgather.c OBJ_RELEASE(schedule); schedule 106 ompi/mca/coll/libnbc/nbc_ineighbor_allgather.c res = NBC_Sched_send ((char *) sbuf, false, scount, stype, dsts[i], schedule, false); schedule 116 ompi/mca/coll/libnbc/nbc_ineighbor_allgather.c OBJ_RELEASE(schedule); schedule 120 ompi/mca/coll/libnbc/nbc_ineighbor_allgather.c res = NBC_Sched_commit (schedule); schedule 122 ompi/mca/coll/libnbc/nbc_ineighbor_allgather.c OBJ_RELEASE(schedule); schedule 136 ompi/mca/coll/libnbc/nbc_ineighbor_allgather.c args->schedule = schedule; schedule 139 ompi/mca/coll/libnbc/nbc_ineighbor_allgather.c OBJ_RETAIN(schedule); schedule 152 ompi/mca/coll/libnbc/nbc_ineighbor_allgather.c schedule = found->schedule; schedule 153 ompi/mca/coll/libnbc/nbc_ineighbor_allgather.c OBJ_RETAIN(schedule); schedule 157 ompi/mca/coll/libnbc/nbc_ineighbor_allgather.c res = NBC_Schedule_request(schedule, comm, libnbc_module, persistent, request, NULL); schedule 159 ompi/mca/coll/libnbc/nbc_ineighbor_allgather.c OBJ_RELEASE(schedule); schedule 54 ompi/mca/coll/libnbc/nbc_ineighbor_allgatherv.c NBC_Schedule *schedule; schedule 76 ompi/mca/coll/libnbc/nbc_ineighbor_allgatherv.c schedule = OBJ_NEW(NBC_Schedule); schedule 77 ompi/mca/coll/libnbc/nbc_ineighbor_allgatherv.c if (OPAL_UNLIKELY(NULL == schedule)) { schedule 83 ompi/mca/coll/libnbc/nbc_ineighbor_allgatherv.c OBJ_RELEASE(schedule); schedule 90 ompi/mca/coll/libnbc/nbc_ineighbor_allgatherv.c res = NBC_Sched_recv ((char *) rbuf + displs[i] * rcvext, false, rcounts[i], rtype, srcs[i], schedule, false); schedule 101 ompi/mca/coll/libnbc/nbc_ineighbor_allgatherv.c OBJ_RELEASE(schedule); schedule 107 ompi/mca/coll/libnbc/nbc_ineighbor_allgatherv.c res = NBC_Sched_send ((char *) sbuf, false, scount, stype, dsts[i], schedule, false); schedule 117 ompi/mca/coll/libnbc/nbc_ineighbor_allgatherv.c OBJ_RELEASE(schedule); schedule 121 ompi/mca/coll/libnbc/nbc_ineighbor_allgatherv.c res = NBC_Sched_commit (schedule); schedule 123 ompi/mca/coll/libnbc/nbc_ineighbor_allgatherv.c OBJ_RELEASE(schedule); schedule 136 ompi/mca/coll/libnbc/nbc_ineighbor_allgatherv.c args->schedule = schedule; schedule 139 ompi/mca/coll/libnbc/nbc_ineighbor_allgatherv.c OBJ_RETAIN(schedule); schedule 153 ompi/mca/coll/libnbc/nbc_ineighbor_allgatherv.c schedule = found->schedule; schedule 154 ompi/mca/coll/libnbc/nbc_ineighbor_allgatherv.c OBJ_RETAIN(schedule); schedule 158 ompi/mca/coll/libnbc/nbc_ineighbor_allgatherv.c res = NBC_Schedule_request(schedule, comm, libnbc_module, persistent, request, NULL); schedule 160 ompi/mca/coll/libnbc/nbc_ineighbor_allgatherv.c OBJ_RELEASE(schedule); schedule 51 ompi/mca/coll/libnbc/nbc_ineighbor_alltoall.c NBC_Schedule *schedule; schedule 79 ompi/mca/coll/libnbc/nbc_ineighbor_alltoall.c schedule = OBJ_NEW(NBC_Schedule); schedule 80 ompi/mca/coll/libnbc/nbc_ineighbor_alltoall.c if (OPAL_UNLIKELY(NULL == schedule)) { schedule 86 ompi/mca/coll/libnbc/nbc_ineighbor_alltoall.c OBJ_RELEASE(schedule); schedule 92 ompi/mca/coll/libnbc/nbc_ineighbor_alltoall.c res = NBC_Sched_recv ((char *) rbuf + i * rcount * rcvext, true, rcount, rtype, srcs[i], schedule, false); schedule 102 ompi/mca/coll/libnbc/nbc_ineighbor_alltoall.c OBJ_RELEASE(schedule); schedule 109 ompi/mca/coll/libnbc/nbc_ineighbor_alltoall.c res = NBC_Sched_send ((char *) sbuf + i * scount * sndext, false, scount, stype, dsts[i], schedule, false); schedule 119 ompi/mca/coll/libnbc/nbc_ineighbor_alltoall.c OBJ_RELEASE(schedule); schedule 123 ompi/mca/coll/libnbc/nbc_ineighbor_alltoall.c res = NBC_Sched_commit (schedule); schedule 125 ompi/mca/coll/libnbc/nbc_ineighbor_alltoall.c OBJ_RELEASE(schedule); schedule 139 ompi/mca/coll/libnbc/nbc_ineighbor_alltoall.c args->schedule = schedule; schedule 142 ompi/mca/coll/libnbc/nbc_ineighbor_alltoall.c OBJ_RETAIN(schedule); schedule 156 ompi/mca/coll/libnbc/nbc_ineighbor_alltoall.c schedule = found->schedule; schedule 157 ompi/mca/coll/libnbc/nbc_ineighbor_alltoall.c OBJ_RETAIN(schedule); schedule 161 ompi/mca/coll/libnbc/nbc_ineighbor_alltoall.c res = NBC_Schedule_request(schedule, comm, libnbc_module, persistent, request, NULL); schedule 163 ompi/mca/coll/libnbc/nbc_ineighbor_alltoall.c OBJ_RELEASE(schedule); schedule 54 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallv.c NBC_Schedule *schedule; schedule 82 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallv.c schedule = OBJ_NEW(NBC_Schedule); schedule 83 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallv.c if (OPAL_UNLIKELY(NULL == schedule)) { schedule 89 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallv.c OBJ_RELEASE(schedule); schedule 96 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallv.c res = NBC_Sched_recv ((char *) rbuf + rdispls[i] * rcvext, false, rcounts[i], rtype, srcs[i], schedule, false); schedule 106 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallv.c OBJ_RELEASE(schedule); schedule 113 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallv.c res = NBC_Sched_send ((char *) sbuf + sdispls[i] * sndext, false, scounts[i], stype, dsts[i], schedule, false); schedule 123 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallv.c OBJ_RELEASE(schedule); schedule 127 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallv.c res = NBC_Sched_commit (schedule); schedule 129 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallv.c OBJ_RELEASE(schedule); schedule 143 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallv.c args->schedule = schedule; schedule 146 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallv.c OBJ_RETAIN(schedule); schedule 160 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallv.c schedule = found->schedule; schedule 161 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallv.c OBJ_RETAIN(schedule); schedule 165 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallv.c res = NBC_Schedule_request(schedule, comm, libnbc_module, persistent, request, NULL); schedule 167 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallv.c OBJ_RELEASE(schedule); schedule 52 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallw.c NBC_Schedule *schedule; schedule 68 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallw.c schedule = OBJ_NEW(NBC_Schedule); schedule 69 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallw.c if (OPAL_UNLIKELY(NULL == schedule)) { schedule 75 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallw.c OBJ_RELEASE(schedule); schedule 82 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallw.c res = NBC_Sched_recv ((char *) rbuf + rdisps[i], false, rcounts[i], rtypes[i], srcs[i], schedule, false); schedule 93 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallw.c OBJ_RELEASE(schedule); schedule 99 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallw.c res = NBC_Sched_send ((char *) sbuf + sdisps[i], false, scounts[i], stypes[i], dsts[i], schedule, false); schedule 109 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallw.c OBJ_RELEASE(schedule); schedule 113 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallw.c res = NBC_Sched_commit(schedule); schedule 115 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallw.c OBJ_RELEASE(schedule); schedule 129 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallw.c args->schedule = schedule; schedule 132 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallw.c OBJ_RETAIN(schedule); schedule 145 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallw.c schedule = found->schedule; schedule 146 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallw.c OBJ_RETAIN(schedule); schedule 150 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallw.c res = NBC_Schedule_request(schedule, comm, libnbc_module, persistent, request, NULL); schedule 152 ompi/mca/coll/libnbc/nbc_ineighbor_alltoallw.c OBJ_RELEASE(schedule); schedule 149 ompi/mca/coll/libnbc/nbc_internal.h int NBC_Sched_send (const void* buf, char tmpbuf, int count, MPI_Datatype datatype, int dest, NBC_Schedule *schedule, bool barrier); schedule 150 ompi/mca/coll/libnbc/nbc_internal.h int NBC_Sched_local_send (const void* buf, char tmpbuf, int count, MPI_Datatype datatype, int dest,NBC_Schedule *schedule, bool barrier); schedule 151 ompi/mca/coll/libnbc/nbc_internal.h int NBC_Sched_recv (void* buf, char tmpbuf, int count, MPI_Datatype datatype, int source, NBC_Schedule *schedule, bool barrier); schedule 152 ompi/mca/coll/libnbc/nbc_internal.h int NBC_Sched_local_recv (void* buf, char tmpbuf, int count, MPI_Datatype datatype, int source, NBC_Schedule *schedule, bool barrier); schedule 154 ompi/mca/coll/libnbc/nbc_internal.h MPI_Op op, NBC_Schedule *schedule, bool barrier); schedule 156 ompi/mca/coll/libnbc/nbc_internal.h MPI_Datatype tgttype, NBC_Schedule *schedule, bool barrier); schedule 158 ompi/mca/coll/libnbc/nbc_internal.h NBC_Schedule *schedule, bool barrier); schedule 160 ompi/mca/coll/libnbc/nbc_internal.h int NBC_Sched_barrier (NBC_Schedule *schedule); schedule 161 ompi/mca/coll/libnbc/nbc_internal.h int NBC_Sched_commit (NBC_Schedule *schedule); schedule 169 ompi/mca/coll/libnbc/nbc_internal.h NBC_Schedule *schedule; schedule 173 ompi/mca/coll/libnbc/nbc_internal.h NBC_Schedule *schedule; schedule 184 ompi/mca/coll/libnbc/nbc_internal.h NBC_Schedule *schedule; schedule 195 ompi/mca/coll/libnbc/nbc_internal.h NBC_Schedule *schedule; schedule 205 ompi/mca/coll/libnbc/nbc_internal.h NBC_Schedule *schedule; schedule 214 ompi/mca/coll/libnbc/nbc_internal.h NBC_Schedule *schedule; schedule 226 ompi/mca/coll/libnbc/nbc_internal.h NBC_Schedule *schedule; schedule 237 ompi/mca/coll/libnbc/nbc_internal.h NBC_Schedule *schedule; schedule 247 ompi/mca/coll/libnbc/nbc_internal.h NBC_Schedule *schedule; schedule 266 ompi/mca/coll/libnbc/nbc_internal.h int NBC_Schedule_request(NBC_Schedule *schedule, ompi_communicator_t *comm, schedule 349 ompi/mca/coll/libnbc/nbc_internal.h static inline int nbc_schedule_get_size (NBC_Schedule *schedule) { schedule 350 ompi/mca/coll/libnbc/nbc_internal.h return schedule->size; schedule 354 ompi/mca/coll/libnbc/nbc_internal.h static inline void nbc_schedule_inc_size (NBC_Schedule *schedule, int size) { schedule 355 ompi/mca/coll/libnbc/nbc_internal.h schedule->size += size; schedule 359 ompi/mca/coll/libnbc/nbc_internal.h static inline void nbc_schedule_inc_round (NBC_Schedule *schedule) { schedule 363 ompi/mca/coll/libnbc/nbc_internal.h lastround = schedule->data + schedule->current_round_offset; schedule 385 ompi/mca/coll/libnbc/nbc_internal.h #define NBC_PRINT_ROUND(schedule) \ schedule 388 ompi/mca/coll/libnbc/nbc_internal.h char *p = (char*) schedule; \ schedule 403 ompi/mca/coll/libnbc/nbc_internal.h printf("[%i] SEND (offset %li) ", myrank, (long)p-(long)schedule); \ schedule 408 ompi/mca/coll/libnbc/nbc_internal.h printf("[%i] RECV (offset %li) ", myrank, (long)p-(long)schedule); \ schedule 413 ompi/mca/coll/libnbc/nbc_internal.h printf("[%i] OP (offset %li) ", myrank, (long)p-(long)schedule); \ schedule 418 ompi/mca/coll/libnbc/nbc_internal.h printf("[%i] COPY (offset %li) ", myrank, (long)p-(long)schedule); \ schedule 423 ompi/mca/coll/libnbc/nbc_internal.h printf("[%i] UNPACK (offset %li) ", myrank, (long)p-(long)schedule); \ schedule 428 ompi/mca/coll/libnbc/nbc_internal.h printf("[%i] NBC_PRINT_ROUND: bad type %i at offset %li\n", myrank, type, (long)p-sizeof(type)-(long)schedule); \ schedule 435 ompi/mca/coll/libnbc/nbc_internal.h #define NBC_PRINT_SCHED(schedule) \ schedule 441 ompi/mca/coll/libnbc/nbc_internal.h NBC_GET_SIZE(schedule, size); \ schedule 446 ompi/mca/coll/libnbc/nbc_internal.h ptr = (char*)schedule+sizeof(int); \ schedule 447 ompi/mca/coll/libnbc/nbc_internal.h while ((long)ptr-(long)schedule < size) { \ schedule 449 ompi/mca/coll/libnbc/nbc_internal.h printf("[%i] Round at byte %li (size %li) ", myrank, (long)ptr-(long)schedule, round_size); \ schedule 30 ompi/mca/coll/libnbc/nbc_ireduce.c MPI_Op op, char inplace, NBC_Schedule *schedule, void *tmpbuf); schedule 32 ompi/mca/coll/libnbc/nbc_ireduce.c MPI_Op op, int ext, size_t size, NBC_Schedule *schedule, void *tmpbuf, int fragsize); schedule 35 ompi/mca/coll/libnbc/nbc_ireduce.c MPI_Op op, NBC_Schedule *schedule); schedule 39 ompi/mca/coll/libnbc/nbc_ireduce.c NBC_Schedule *schedule, void *tmp_buf, struct ompi_communicator_t *comm); schedule 68 ompi/mca/coll/libnbc/nbc_ireduce.c NBC_Schedule *schedule; schedule 163 ompi/mca/coll/libnbc/nbc_ireduce.c schedule = OBJ_NEW(NBC_Schedule); schedule 164 ompi/mca/coll/libnbc/nbc_ireduce.c if (OPAL_UNLIKELY(NULL == schedule)) { schedule 171 ompi/mca/coll/libnbc/nbc_ireduce.c recvbuf, false, count, datatype, schedule, false); schedule 175 ompi/mca/coll/libnbc/nbc_ireduce.c res = red_sched_binomial(rank, p, root, sendbuf, redbuf, tmpredbuf, count, datatype, op, inplace, schedule, tmpbuf); schedule 178 ompi/mca/coll/libnbc/nbc_ireduce.c res = red_sched_chain(rank, p, root, sendbuf, recvbuf, count, datatype, op, ext, size, schedule, tmpbuf, segsize); schedule 181 ompi/mca/coll/libnbc/nbc_ireduce.c res = red_sched_redscat_gather(rank, p, root, sendbuf, redbuf, tmpredbuf, count, datatype, op, inplace, schedule, tmpbuf, comm); schedule 187 ompi/mca/coll/libnbc/nbc_ireduce.c OBJ_RELEASE(schedule); schedule 192 ompi/mca/coll/libnbc/nbc_ireduce.c res = NBC_Sched_commit(schedule); schedule 194 ompi/mca/coll/libnbc/nbc_ireduce.c OBJ_RELEASE(schedule); schedule 208 ompi/mca/coll/libnbc/nbc_ireduce.c args->schedule = schedule; schedule 211 ompi/mca/coll/libnbc/nbc_ireduce.c OBJ_RETAIN(schedule); schedule 225 ompi/mca/coll/libnbc/nbc_ireduce.c schedule = found->schedule; schedule 226 ompi/mca/coll/libnbc/nbc_ireduce.c OBJ_RETAIN(schedule); schedule 230 ompi/mca/coll/libnbc/nbc_ireduce.c res = NBC_Schedule_request(schedule, comm, libnbc_module, persistent, request, tmpbuf); schedule 232 ompi/mca/coll/libnbc/nbc_ireduce.c OBJ_RELEASE(schedule); schedule 262 ompi/mca/coll/libnbc/nbc_ireduce.c NBC_Schedule *schedule; schedule 276 ompi/mca/coll/libnbc/nbc_ireduce.c schedule = OBJ_NEW(NBC_Schedule); schedule 277 ompi/mca/coll/libnbc/nbc_ireduce.c if (OPAL_UNLIKELY(NULL == schedule)) { schedule 282 ompi/mca/coll/libnbc/nbc_ireduce.c res = red_sched_linear (rank, rsize, root, sendbuf, recvbuf, (void *)(-gap), count, datatype, op, schedule); schedule 284 ompi/mca/coll/libnbc/nbc_ireduce.c OBJ_RELEASE(schedule); schedule 289 ompi/mca/coll/libnbc/nbc_ireduce.c res = NBC_Sched_commit(schedule); schedule 291 ompi/mca/coll/libnbc/nbc_ireduce.c OBJ_RELEASE(schedule); schedule 296 ompi/mca/coll/libnbc/nbc_ireduce.c res = NBC_Schedule_request(schedule, comm, libnbc_module, persistent, request, tmpbuf); schedule 298 ompi/mca/coll/libnbc/nbc_ireduce.c OBJ_RELEASE(schedule); schedule 357 ompi/mca/coll/libnbc/nbc_ireduce.c MPI_Op op, char inplace, NBC_Schedule *schedule, void *tmpbuf) { schedule 390 ompi/mca/coll/libnbc/nbc_ireduce.c schedule, true); schedule 405 ompi/mca/coll/libnbc/nbc_ireduce.c res = NBC_Sched_recv (rbuf, tmprbuf, count, datatype, peer, schedule, true); schedule 414 ompi/mca/coll/libnbc/nbc_ireduce.c res = NBC_Sched_op (sendbuf, false, rbuf, tmprbuf, count, datatype, op, schedule, true); schedule 418 ompi/mca/coll/libnbc/nbc_ireduce.c res = NBC_Sched_op (lbuf, tmplbuf, rbuf, tmprbuf, count, datatype, op, schedule, true); schedule 434 ompi/mca/coll/libnbc/nbc_ireduce.c res = NBC_Sched_send (sendbuf, false, count, datatype, peer, schedule, false); schedule 437 ompi/mca/coll/libnbc/nbc_ireduce.c res = NBC_Sched_send (lbuf, tmplbuf, count, datatype, peer, schedule, false); schedule 451 ompi/mca/coll/libnbc/nbc_ireduce.c res = NBC_Sched_send (redbuf, tmpredbuf, count, datatype, root, schedule, false); schedule 453 ompi/mca/coll/libnbc/nbc_ireduce.c res = NBC_Sched_recv (redbuf, tmpredbuf, count, datatype, vroot, schedule, false); schedule 462 ompi/mca/coll/libnbc/nbc_ireduce.c MPI_Op op, int ext, size_t size, NBC_Schedule *schedule, void *tmpbuf, int fragsize) { schedule 492 ompi/mca/coll/libnbc/nbc_ireduce.c res = NBC_Sched_recv ((char *)recvbuf+offset, false, thiscount, datatype, rpeer, schedule, true); schedule 494 ompi/mca/coll/libnbc/nbc_ireduce.c res = NBC_Sched_recv ((char *)offset, true, thiscount, datatype, rpeer, schedule, true); schedule 504 ompi/mca/coll/libnbc/nbc_ireduce.c thiscount, datatype, op, schedule, true); schedule 507 ompi/mca/coll/libnbc/nbc_ireduce.c thiscount, datatype, op, schedule, true); schedule 511 ompi/mca/coll/libnbc/nbc_ireduce.c datatype, op, schedule, true); schedule 524 ompi/mca/coll/libnbc/nbc_ireduce.c res = NBC_Sched_send ((char *) sendbuf + offset, false, thiscount, datatype, speer, schedule, true); schedule 526 ompi/mca/coll/libnbc/nbc_ireduce.c res = NBC_Sched_send ((char *) offset, true, thiscount, datatype, speer, schedule, true); schedule 540 ompi/mca/coll/libnbc/nbc_ireduce.c MPI_Op op, NBC_Schedule *schedule) { schedule 563 ompi/mca/coll/libnbc/nbc_ireduce.c res = NBC_Sched_recv (lbuf, tmplbuf, count, datatype, 0, schedule, false); schedule 569 ompi/mca/coll/libnbc/nbc_ireduce.c res = NBC_Sched_recv (rbuf, tmprbuf, count, datatype, peer, schedule, true); schedule 574 ompi/mca/coll/libnbc/nbc_ireduce.c res = NBC_Sched_op (lbuf, tmplbuf, rbuf, tmprbuf, count, datatype, op, schedule, true); schedule 583 ompi/mca/coll/libnbc/nbc_ireduce.c res = NBC_Sched_send (sendbuf, false, count, datatype, root, schedule, true); schedule 652 ompi/mca/coll/libnbc/nbc_ireduce.c NBC_Schedule *schedule, void *tmp_buf, struct ompi_communicator_t *comm) schedule 670 ompi/mca/coll/libnbc/nbc_ireduce.c rbuf, tmpredbuf, count, datatype, schedule, true); schedule 706 ompi/mca/coll/libnbc/nbc_ireduce.c schedule, false); schedule 710 ompi/mca/coll/libnbc/nbc_ireduce.c false, count_rhalf, datatype, rank - 1, schedule, true); schedule 715 ompi/mca/coll/libnbc/nbc_ireduce.c tmpredbuf, count_rhalf, datatype, op, schedule, true); schedule 720 ompi/mca/coll/libnbc/nbc_ireduce.c tmpredbuf, count_rhalf, datatype, rank - 1, schedule, true); schedule 733 ompi/mca/coll/libnbc/nbc_ireduce.c tmpredbuf, count_rhalf, datatype, rank + 1, schedule, false); schedule 737 ompi/mca/coll/libnbc/nbc_ireduce.c schedule, true); schedule 741 ompi/mca/coll/libnbc/nbc_ireduce.c datatype, op, schedule, true); schedule 746 ompi/mca/coll/libnbc/nbc_ireduce.c tmpredbuf, count_rhalf, datatype, rank + 1, schedule, true); schedule 813 ompi/mca/coll/libnbc/nbc_ireduce.c tmpredbuf, scount[step], datatype, dest, schedule, false); schedule 816 ompi/mca/coll/libnbc/nbc_ireduce.c false, rcount[step], datatype, dest, schedule, true); schedule 822 ompi/mca/coll/libnbc/nbc_ireduce.c tmpredbuf, rcount[step], datatype, op, schedule, true); schedule 868 ompi/mca/coll/libnbc/nbc_ireduce.c 0, schedule, true); schedule 875 ompi/mca/coll/libnbc/nbc_ireduce.c root, schedule, true); schedule 915 ompi/mca/coll/libnbc/nbc_ireduce.c tmpredbuf, rcount[step], datatype, dest, schedule, false); schedule 921 ompi/mca/coll/libnbc/nbc_ireduce.c tmpredbuf, scount[step], datatype, dest, schedule, true); schedule 52 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c NBC_Schedule *schedule; schedule 97 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c schedule = OBJ_NEW(NBC_Schedule); schedule 98 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c if (OPAL_UNLIKELY(NULL == schedule)) { schedule 109 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c res = NBC_Sched_recv(rbuf, true, count, datatype, peer, schedule, true); schedule 111 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c OBJ_RELEASE(schedule); schedule 119 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c res = NBC_Sched_op (sendbuf, false, rbuf, true, count, datatype, op, schedule, true); schedule 123 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c res = NBC_Sched_op (lbuf, true, rbuf, true, count, datatype, op, schedule, true); schedule 127 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c OBJ_RELEASE(schedule); schedule 139 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c res = NBC_Sched_send (sendbuf, false, count, datatype, peer, schedule, false); schedule 142 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c res = NBC_Sched_send (lbuf, true, count, datatype, peer, schedule, false); schedule 145 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c OBJ_RELEASE(schedule); schedule 155 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c res = NBC_Sched_barrier(schedule); schedule 157 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c OBJ_RELEASE(schedule); schedule 168 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c res = NBC_Sched_send (sbuf, true, recvcounts[r], datatype, r, schedule, schedule 171 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c OBJ_RELEASE(schedule); schedule 180 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c recvbuf, false, recvcounts[0], datatype, schedule, false); schedule 183 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c recvcounts[0], datatype, schedule, false); schedule 186 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c res = NBC_Sched_recv (recvbuf, false, recvcounts[rank], datatype, 0, schedule, false); schedule 190 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c OBJ_RELEASE(schedule); schedule 195 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c res = NBC_Sched_commit (schedule); schedule 197 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c OBJ_RELEASE(schedule); schedule 202 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c res = NBC_Schedule_request(schedule, comm, libnbc_module, persistent, request, tmpbuf); schedule 204 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c OBJ_RELEASE(schedule); schedule 235 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c NBC_Schedule *schedule; schedule 264 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c schedule = OBJ_NEW(NBC_Schedule); schedule 265 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c if (OPAL_UNLIKELY(NULL == schedule)) { schedule 271 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c res = NBC_Sched_send(sendbuf, false, count, datatype, 0, schedule, false); schedule 273 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c OBJ_RELEASE(schedule); schedule 282 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c res = NBC_Sched_recv (lbuf, true, count, datatype, 0, schedule, true); schedule 284 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c OBJ_RELEASE(schedule); schedule 291 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c res = NBC_Sched_recv (rbuf, true, count, datatype, peer, schedule, true); schedule 293 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c OBJ_RELEASE(schedule); schedule 299 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c op, schedule, true); schedule 301 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c OBJ_RELEASE(schedule); schedule 310 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c recvcounts[0], datatype, schedule, false); schedule 312 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c OBJ_RELEASE(schedule); schedule 317 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c res = NBC_Sched_local_send (lbuf + offset, true, recvcounts[peer], datatype, peer, schedule, schedule 320 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c OBJ_RELEASE(schedule); schedule 329 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c res = NBC_Sched_local_recv (recvbuf, false, recvcounts[rank], datatype, 0, schedule, false); schedule 331 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c OBJ_RELEASE(schedule); schedule 337 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c res = NBC_Sched_commit (schedule); schedule 339 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c OBJ_RELEASE(schedule); schedule 344 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c res = NBC_Schedule_request(schedule, comm, libnbc_module, persistent, request, tmpbuf); schedule 346 ompi/mca/coll/libnbc/nbc_ireduce_scatter.c OBJ_RELEASE(schedule); schedule 50 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c NBC_Schedule *schedule; schedule 65 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c schedule = OBJ_NEW(NBC_Schedule); schedule 66 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c if (NULL == schedule) { schedule 82 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c OBJ_RELEASE(schedule); schedule 93 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c redbuf, false, count, datatype, schedule, false); schedule 95 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c OBJ_RELEASE(schedule); schedule 107 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c res = NBC_Sched_recv (rbuf, true, count, datatype, peer, schedule, true); schedule 109 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c OBJ_RELEASE(schedule); schedule 116 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c res = NBC_Sched_op (sendbuf, false, rbuf, true, count, datatype, op, schedule, true); schedule 120 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c res = NBC_Sched_op (lbuf, true, rbuf, true, count, datatype, op, schedule, true); schedule 124 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c OBJ_RELEASE(schedule); schedule 136 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c res = NBC_Sched_send (sendbuf, false, count, datatype, peer, schedule, false); schedule 139 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c res = NBC_Sched_send (lbuf, true, count, datatype, peer, schedule, false); schedule 143 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c OBJ_RELEASE(schedule); schedule 153 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c res = NBC_Sched_barrier(schedule); schedule 155 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c OBJ_RELEASE(schedule); schedule 162 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c res = NBC_Sched_recv (recvbuf, false, recvcount, datatype, 0, schedule, false); schedule 164 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c OBJ_RELEASE(schedule); schedule 173 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c res = NBC_Sched_send (sbuf, true, recvcount, datatype, r, schedule, false); schedule 175 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c OBJ_RELEASE(schedule); schedule 183 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c datatype, schedule, false); schedule 186 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c OBJ_RELEASE(schedule); schedule 193 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c res = NBC_Sched_commit (schedule); schedule 195 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c OBJ_RELEASE(schedule); schedule 200 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c res = NBC_Schedule_request(schedule, comm, libnbc_module, persistent, request, tmpbuf); schedule 202 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c OBJ_RELEASE(schedule); schedule 234 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c NBC_Schedule *schedule; schedule 260 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c schedule = OBJ_NEW(NBC_Schedule); schedule 261 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c if (NULL == schedule) { schedule 267 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c res = NBC_Sched_send (sendbuf, false, count, dtype, 0, schedule, false); schedule 269 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c OBJ_RELEASE(schedule); schedule 278 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c res = NBC_Sched_recv (lbuf, true, count, dtype, 0, schedule, true); schedule 280 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c OBJ_RELEASE(schedule); schedule 287 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c res = NBC_Sched_recv (rbuf, true, count, dtype, peer, schedule, true); schedule 289 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c OBJ_RELEASE(schedule); schedule 295 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c op, schedule, true); schedule 297 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c OBJ_RELEASE(schedule); schedule 306 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c dtype, schedule, false); schedule 308 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c OBJ_RELEASE(schedule); schedule 313 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c res = NBC_Sched_local_send (lbuf + ext * rcount * peer, true, rcount, dtype, peer, schedule, false); schedule 315 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c OBJ_RELEASE(schedule); schedule 322 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c res = NBC_Sched_local_recv(recvbuf, false, rcount, dtype, 0, schedule, false); schedule 324 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c OBJ_RELEASE(schedule); schedule 332 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c res = NBC_Sched_commit(schedule); schedule 334 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c OBJ_RELEASE(schedule); schedule 339 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c res = NBC_Schedule_request(schedule, comm, libnbc_module, persistent, request, tmpbuf); schedule 341 ompi/mca/coll/libnbc/nbc_ireduce_scatter_block.c OBJ_RELEASE(schedule); schedule 28 ompi/mca/coll/libnbc/nbc_iscan.c MPI_Datatype datatype, MPI_Op op, char inplace, NBC_Schedule *schedule, schedule 33 ompi/mca/coll/libnbc/nbc_iscan.c NBC_Schedule *schedule, void *tmpbuf1, void *tmpbuf2); schedule 59 ompi/mca/coll/libnbc/nbc_iscan.c NBC_Schedule *schedule; schedule 102 ompi/mca/coll/libnbc/nbc_iscan.c schedule = OBJ_NEW(NBC_Schedule); schedule 103 ompi/mca/coll/libnbc/nbc_iscan.c if (OPAL_UNLIKELY(NULL == schedule)) { schedule 110 ompi/mca/coll/libnbc/nbc_iscan.c op, inplace, schedule, tmpbuf); schedule 113 ompi/mca/coll/libnbc/nbc_iscan.c datatype, op, inplace, schedule, tmpbuf1, tmpbuf2); schedule 116 ompi/mca/coll/libnbc/nbc_iscan.c OBJ_RELEASE(schedule); schedule 121 ompi/mca/coll/libnbc/nbc_iscan.c res = NBC_Sched_commit(schedule); schedule 123 ompi/mca/coll/libnbc/nbc_iscan.c OBJ_RELEASE(schedule); schedule 137 ompi/mca/coll/libnbc/nbc_iscan.c args->schedule = schedule; schedule 140 ompi/mca/coll/libnbc/nbc_iscan.c OBJ_RETAIN(schedule); schedule 154 ompi/mca/coll/libnbc/nbc_iscan.c schedule = found->schedule; schedule 155 ompi/mca/coll/libnbc/nbc_iscan.c OBJ_RETAIN(schedule); schedule 159 ompi/mca/coll/libnbc/nbc_iscan.c res = NBC_Schedule_request(schedule, comm, libnbc_module, persistent, request, tmpbuf); schedule 161 ompi/mca/coll/libnbc/nbc_iscan.c OBJ_RELEASE(schedule); schedule 185 ompi/mca/coll/libnbc/nbc_iscan.c MPI_Datatype datatype, MPI_Op op, char inplace, NBC_Schedule *schedule, schedule 193 ompi/mca/coll/libnbc/nbc_iscan.c recvbuf, false, count, datatype, schedule, false); schedule 201 ompi/mca/coll/libnbc/nbc_iscan.c res = NBC_Sched_recv((void *)(-gap), true, count, datatype, rank - 1, schedule, true); schedule 206 ompi/mca/coll/libnbc/nbc_iscan.c res = NBC_Sched_op((void *)(-gap), true, recvbuf, false, count, datatype, op, schedule, schedule 212 ompi/mca/coll/libnbc/nbc_iscan.c res = NBC_Sched_send(recvbuf, false, count, datatype, rank + 1, schedule, false); schedule 256 ompi/mca/coll/libnbc/nbc_iscan.c NBC_Schedule *schedule, void *tmpbuf1, void *tmpbuf2) schedule 262 ompi/mca/coll/libnbc/nbc_iscan.c recvbuf, false, count, datatype, schedule, true); schedule 271 ompi/mca/coll/libnbc/nbc_iscan.c psend, true, count, datatype, schedule, true); schedule 278 ompi/mca/coll/libnbc/nbc_iscan.c res = NBC_Sched_send(psend, true, count, datatype, remote, schedule, false); schedule 280 ompi/mca/coll/libnbc/nbc_iscan.c res = NBC_Sched_recv(precv, true, count, datatype, remote, schedule, true); schedule 286 ompi/mca/coll/libnbc/nbc_iscan.c datatype, op, schedule, false); schedule 290 ompi/mca/coll/libnbc/nbc_iscan.c datatype, op, schedule, true); schedule 296 ompi/mca/coll/libnbc/nbc_iscan.c datatype, op, schedule, true); schedule 301 ompi/mca/coll/libnbc/nbc_iscan.c datatype, op, schedule, true); schedule 54 ompi/mca/coll/libnbc/nbc_iscatter.c NBC_Schedule *schedule; schedule 87 ompi/mca/coll/libnbc/nbc_iscatter.c schedule = OBJ_NEW(NBC_Schedule); schedule 88 ompi/mca/coll/libnbc/nbc_iscatter.c if (OPAL_UNLIKELY(NULL == schedule)) { schedule 95 ompi/mca/coll/libnbc/nbc_iscatter.c res = NBC_Sched_recv (recvbuf, false, recvcount, recvtype, root, schedule, false); schedule 97 ompi/mca/coll/libnbc/nbc_iscatter.c OBJ_RELEASE(schedule); schedule 107 ompi/mca/coll/libnbc/nbc_iscatter.c recvbuf, false, recvcount, recvtype, schedule, false); schedule 109 ompi/mca/coll/libnbc/nbc_iscatter.c OBJ_RELEASE(schedule); schedule 115 ompi/mca/coll/libnbc/nbc_iscatter.c res = NBC_Sched_send (sbuf, false, sendcount, sendtype, i, schedule, false); schedule 117 ompi/mca/coll/libnbc/nbc_iscatter.c OBJ_RELEASE(schedule); schedule 124 ompi/mca/coll/libnbc/nbc_iscatter.c res = NBC_Sched_commit (schedule); schedule 126 ompi/mca/coll/libnbc/nbc_iscatter.c OBJ_RELEASE(schedule); schedule 140 ompi/mca/coll/libnbc/nbc_iscatter.c args->schedule = schedule; schedule 143 ompi/mca/coll/libnbc/nbc_iscatter.c OBJ_RETAIN(schedule); schedule 157 ompi/mca/coll/libnbc/nbc_iscatter.c schedule = found->schedule; schedule 158 ompi/mca/coll/libnbc/nbc_iscatter.c OBJ_RETAIN(schedule); schedule 162 ompi/mca/coll/libnbc/nbc_iscatter.c res = NBC_Schedule_request(schedule, comm, libnbc_module, persistent, request, NULL); schedule 164 ompi/mca/coll/libnbc/nbc_iscatter.c OBJ_RELEASE(schedule); schedule 196 ompi/mca/coll/libnbc/nbc_iscatter.c NBC_Schedule *schedule; schedule 210 ompi/mca/coll/libnbc/nbc_iscatter.c schedule = OBJ_NEW(NBC_Schedule); schedule 211 ompi/mca/coll/libnbc/nbc_iscatter.c if (OPAL_UNLIKELY(NULL == schedule)) { schedule 218 ompi/mca/coll/libnbc/nbc_iscatter.c res = NBC_Sched_recv(recvbuf, false, recvcount, recvtype, root, schedule, false); schedule 220 ompi/mca/coll/libnbc/nbc_iscatter.c OBJ_RELEASE(schedule); schedule 227 ompi/mca/coll/libnbc/nbc_iscatter.c res = NBC_Sched_send(sbuf, false, sendcount, sendtype, i, schedule, false); schedule 229 ompi/mca/coll/libnbc/nbc_iscatter.c OBJ_RELEASE(schedule); schedule 235 ompi/mca/coll/libnbc/nbc_iscatter.c res = NBC_Sched_commit(schedule); schedule 237 ompi/mca/coll/libnbc/nbc_iscatter.c OBJ_RELEASE(schedule); schedule 241 ompi/mca/coll/libnbc/nbc_iscatter.c res = NBC_Schedule_request(schedule, comm, libnbc_module, persistent, request, NULL); schedule 243 ompi/mca/coll/libnbc/nbc_iscatter.c OBJ_RELEASE(schedule); schedule 37 ompi/mca/coll/libnbc/nbc_iscatterv.c NBC_Schedule *schedule; schedule 48 ompi/mca/coll/libnbc/nbc_iscatterv.c schedule = OBJ_NEW(NBC_Schedule); schedule 49 ompi/mca/coll/libnbc/nbc_iscatterv.c if (OPAL_UNLIKELY(NULL == schedule)) { schedule 58 ompi/mca/coll/libnbc/nbc_iscatterv.c OBJ_RELEASE(schedule); schedule 68 ompi/mca/coll/libnbc/nbc_iscatterv.c recvbuf, false, recvcount, recvtype, schedule, false); schedule 74 ompi/mca/coll/libnbc/nbc_iscatterv.c res = NBC_Sched_send (sbuf, false, sendcounts[i], sendtype, i, schedule, false); schedule 78 ompi/mca/coll/libnbc/nbc_iscatterv.c OBJ_RELEASE(schedule); schedule 84 ompi/mca/coll/libnbc/nbc_iscatterv.c res = NBC_Sched_recv (recvbuf, false, recvcount, recvtype, root, schedule, false); schedule 86 ompi/mca/coll/libnbc/nbc_iscatterv.c OBJ_RELEASE(schedule); schedule 91 ompi/mca/coll/libnbc/nbc_iscatterv.c res = NBC_Sched_commit (schedule); schedule 93 ompi/mca/coll/libnbc/nbc_iscatterv.c OBJ_RELEASE(schedule); schedule 97 ompi/mca/coll/libnbc/nbc_iscatterv.c res = NBC_Schedule_request(schedule, comm, libnbc_module, persistent, request, NULL); schedule 99 ompi/mca/coll/libnbc/nbc_iscatterv.c OBJ_RELEASE(schedule); schedule 131 ompi/mca/coll/libnbc/nbc_iscatterv.c NBC_Schedule *schedule; schedule 137 ompi/mca/coll/libnbc/nbc_iscatterv.c schedule = OBJ_NEW(NBC_Schedule); schedule 138 ompi/mca/coll/libnbc/nbc_iscatterv.c if (OPAL_UNLIKELY(NULL == schedule)) { schedule 145 ompi/mca/coll/libnbc/nbc_iscatterv.c res = NBC_Sched_recv(recvbuf, false, recvcount, recvtype, root, schedule, false); schedule 147 ompi/mca/coll/libnbc/nbc_iscatterv.c OBJ_RELEASE(schedule); schedule 154 ompi/mca/coll/libnbc/nbc_iscatterv.c OBJ_RELEASE(schedule); schedule 161 ompi/mca/coll/libnbc/nbc_iscatterv.c res = NBC_Sched_send (sbuf, false, sendcounts[i], sendtype, i, schedule, false); schedule 163 ompi/mca/coll/libnbc/nbc_iscatterv.c OBJ_RELEASE(schedule); schedule 169 ompi/mca/coll/libnbc/nbc_iscatterv.c res = NBC_Sched_commit(schedule); schedule 171 ompi/mca/coll/libnbc/nbc_iscatterv.c OBJ_RELEASE(schedule); schedule 175 ompi/mca/coll/libnbc/nbc_iscatterv.c res = NBC_Schedule_request(schedule, comm, libnbc_module, persistent, request, NULL); schedule 177 ompi/mca/coll/libnbc/nbc_iscatterv.c OBJ_RELEASE(schedule);