Skip to content
This repository has been archived by the owner on Jan 28, 2025. It is now read-only.

Creating All Chuncks in AllGather Collective OOP #31

Open
wants to merge 2 commits into
base: main
Choose a base branch
from

Conversation

caiomcbr
Copy link
Collaborator

No description provided.

@caiomcbr caiomcbr requested a review from Binyang2014 December 13, 2024 00:44
if self.create_all_chunks:
for rank in range(self.num_ranks):
for ch in range(self.chunk_factor):
output_buffer[rank * self.chunk_factor + ch] = Chunk(rank, ch, -1, rank * self.chunk_factor + ch)
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

The args for Chunk seems incorrect. There are some comments:

  1. original_rank should always be r I think. For example, for GPU 0, the chunks in output buffer should set original rank to 0
  2. For last two args in Chunk constructor, set it to -1, -1?

Copy link
Collaborator Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

This make sense, I guess you are right. BTW the same is wrong in the inplace scenario, right? I guess that I did the same mistake there.

Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants