Skip to content

Commit

Permalink
123
Browse files Browse the repository at this point in the history
  • Loading branch information
nsarkauskas committed Nov 27, 2024
1 parent 1ab0ac7 commit ca7351d
Show file tree
Hide file tree
Showing 4 changed files with 0 additions and 9 deletions.
1 change: 0 additions & 1 deletion src/components/cl/hier/cl_hier.h
Original file line number Diff line number Diff line change
Expand Up @@ -54,7 +54,6 @@ typedef struct ucc_cl_hier_lib_config {
ucc_pipeline_params_t allreduce_rab_pipeline;
ucc_pipeline_params_t bcast_2step_pipeline;
ucc_pipeline_params_t reduce_2step_pipeline;
ucc_pipeline_params_t allgatherv_node_split_pipeline;
} ucc_cl_hier_lib_config_t;

typedef struct ucc_cl_hier_context_config {
Expand Down
6 changes: 0 additions & 6 deletions src/components/tl/ucp/allgather/allgather_ring.c
Original file line number Diff line number Diff line change
Expand Up @@ -60,11 +60,6 @@ void ucc_tl_ucp_allgather_ring_progress(ucc_coll_task_t *coll_task)
UCPCHECK_GOTO(
ucc_tl_ucp_send_nb(buf, data_size, rmem, sendto, team, task),
task, out);
printf("rank %d sending to rank %d data ptr %p: ", trank, sendto, buf);
for (int z = 0; z < data_size; z++) {
printf("%d ", ((char*)buf)[z]);
}
printf("\n");
buf = PTR_OFFSET(rbuf, rblock * data_size);
UCPCHECK_GOTO(
ucc_tl_ucp_recv_nb(buf, data_size, rmem, recvfrom, team, task),
Expand Down Expand Up @@ -124,7 +119,6 @@ ucc_status_t ucc_tl_ucp_allgather_ring_init_common(ucc_tl_ucp_task_t *task)
if (!(task->flags & UCC_TL_UCP_TASK_FLAG_SUBSET)) {
if (team->cfg.use_reordering) {
sbgp = ucc_topo_get_sbgp(team->topo, UCC_SBGP_FULL_HOST_ORDERED);
printf("nick using rank reordering. old rank=%d, new rank=%d\n", task->subset.myrank, sbgp->group_rank);
task->subset.myrank = sbgp->group_rank;
task->subset.map = sbgp->map;
}
Expand Down
1 change: 0 additions & 1 deletion src/components/topo/ucc_sbgp.c
Original file line number Diff line number Diff line change
Expand Up @@ -142,7 +142,6 @@ static inline ucc_status_t sbgp_create_node(ucc_topo_t *topo, ucc_sbgp_t *sbgp)
ucc_free(local_ranks);
return UCC_ERR_NO_MESSAGE;
}
sbgp->preserves_order = local_ranks[0] == ctx_nlr;
sbgp->group_size = node_size;
sbgp->group_rank = node_rank;
sbgp->rank_map = local_ranks;
Expand Down
1 change: 0 additions & 1 deletion src/components/topo/ucc_sbgp.h
Original file line number Diff line number Diff line change
Expand Up @@ -55,7 +55,6 @@ typedef struct ucc_sbgp_t {
ucc_rank_t group_rank;
ucc_rank_t *rank_map;
ucc_ep_map_t map;
int preserves_order; // True if the order of the ranks of the subgroup is the same as in parent group
} ucc_sbgp_t;

const char* ucc_sbgp_str(ucc_sbgp_type_t type);
Expand Down

0 comments on commit ca7351d

Please sign in to comment.