Merge pull request #1158 from tkordenbrock/topic/cleanup.triggered.gather
coll-portals4: remove unneeded code from gather
Этот коммит содержится в:
Коммит
e93755ce5a
@ -177,10 +177,6 @@ setup_gather_buffers_binomial(struct ompi_communicator_t *comm,
|
|||||||
/* Setup Gather Buffers */
|
/* Setup Gather Buffers */
|
||||||
/**********************************/
|
/**********************************/
|
||||||
if (vrank == 0) {
|
if (vrank == 0) {
|
||||||
request->u.gather.unpack_bytes=
|
|
||||||
request->u.gather.unpack_dst_true_extent +
|
|
||||||
((ptrdiff_t)request->u.gather.unpack_dst_count * (ptrdiff_t)request->u.gather.size - 1) * request->u.gather.unpack_dst_extent;
|
|
||||||
|
|
||||||
request->u.gather.gather_bytes=request->u.gather.packed_size * (ptrdiff_t)request->u.gather.size;
|
request->u.gather.gather_bytes=request->u.gather.packed_size * (ptrdiff_t)request->u.gather.size;
|
||||||
|
|
||||||
/*
|
/*
|
||||||
@ -282,10 +278,6 @@ setup_gather_buffers_linear(struct ompi_communicator_t *comm,
|
|||||||
/* Setup Gather Buffers */
|
/* Setup Gather Buffers */
|
||||||
/**********************************/
|
/**********************************/
|
||||||
if (i_am_root) {
|
if (i_am_root) {
|
||||||
request->u.gather.unpack_bytes=
|
|
||||||
request->u.gather.unpack_dst_true_extent +
|
|
||||||
((ptrdiff_t)request->u.gather.unpack_dst_count * (ptrdiff_t)request->u.gather.size - 1) * request->u.gather.unpack_dst_extent;
|
|
||||||
|
|
||||||
request->u.gather.gather_bytes=request->u.gather.packed_size * (ptrdiff_t)request->u.gather.size;
|
request->u.gather.gather_bytes=request->u.gather.packed_size * (ptrdiff_t)request->u.gather.size;
|
||||||
|
|
||||||
/*
|
/*
|
||||||
@ -1005,8 +997,6 @@ ompi_coll_portals4_gather_intra_linear_top(const void *sbuf, int scount, struct
|
|||||||
"completed CTWait(expected_ops=%d)\n", expected_ops);
|
"completed CTWait(expected_ops=%d)\n", expected_ops);
|
||||||
}
|
}
|
||||||
|
|
||||||
ompi_coll_portals4_destroy_tree(&(portals4_module->cached_in_order_bmtree));
|
|
||||||
|
|
||||||
OPAL_OUTPUT((ompi_coll_base_framework.framework_output,
|
OPAL_OUTPUT((ompi_coll_base_framework.framework_output,
|
||||||
"coll:portals4:gather_intra_linear_top exit rank %d", request->u.gather.my_rank));
|
"coll:portals4:gather_intra_linear_top exit rank %d", request->u.gather.my_rank));
|
||||||
|
|
||||||
@ -1016,8 +1006,6 @@ err_hdlr:
|
|||||||
if (NULL != request->u.gather.gather_buf)
|
if (NULL != request->u.gather.gather_buf)
|
||||||
free(request->u.gather.gather_buf);
|
free(request->u.gather.gather_buf);
|
||||||
|
|
||||||
ompi_coll_portals4_destroy_tree(&(portals4_module->cached_in_order_bmtree));
|
|
||||||
|
|
||||||
opal_output(ompi_coll_base_framework.framework_output,
|
opal_output(ompi_coll_base_framework.framework_output,
|
||||||
"%s:%4d:%4d\tError occurred ret=%d, rank %2d",
|
"%s:%4d:%4d\tError occurred ret=%d, rank %2d",
|
||||||
__FILE__, __LINE__, line, ret, request->u.gather.my_rank);
|
__FILE__, __LINE__, line, ret, request->u.gather.my_rank);
|
||||||
|
@ -114,7 +114,6 @@ struct ompi_coll_portals4_request_t {
|
|||||||
MPI_Aint pack_src_lb;
|
MPI_Aint pack_src_lb;
|
||||||
MPI_Aint pack_src_true_lb;
|
MPI_Aint pack_src_true_lb;
|
||||||
MPI_Aint pack_src_offset;
|
MPI_Aint pack_src_offset;
|
||||||
uint64_t unpack_bytes;
|
|
||||||
char *unpack_dst_buf;
|
char *unpack_dst_buf;
|
||||||
int unpack_dst_count;
|
int unpack_dst_count;
|
||||||
struct ompi_datatype_t *unpack_dst_dtype;
|
struct ompi_datatype_t *unpack_dst_dtype;
|
||||||
|
Загрузка…
x
Ссылка в новой задаче
Block a user