Skip to content

Commit

Permalink
faster network test
Browse files Browse the repository at this point in the history
  • Loading branch information
Roger Waleffe authored and Roger Waleffe committed Nov 22, 2023
1 parent ec42cef commit 73d20b5
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/cpp/src/data/batch.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -91,7 +91,7 @@ void Batch::remoteTo(shared_ptr<c10d::ProcessGroupGloo> pg, int worker_id, int t
}

if (sub_batches_.size() > 0) {
#pragma omp parallel for // TODO: need to look at whether this works or not (e.g., parallel sending)
// #pragma omp parallel for // TODO: need to look at whether this works or not (e.g., parallel sending)
for (int i = 0; i < sub_batches_.size(); i++) {
sub_batches_[i]->remoteTo(pg, worker_id, tag+i, false);
}
Expand Down Expand Up @@ -164,7 +164,7 @@ void Batch::remoteReceive(shared_ptr<c10d::ProcessGroupGloo> pg, int worker_id,
}

if (sub_batches_.size() > 0) {
#pragma omp parallel for // TODO: need to look at whether this works or not (e.g., parallel sending)
// #pragma omp parallel for // TODO: need to look at whether this works or not (e.g., parallel sending)
for (int i = 0; i < sub_batches_.size(); i++) {
sub_batches_[i]->remoteReceive(pg, worker_id, tag + i, false);
}
Expand Down

0 comments on commit 73d20b5

Please sign in to comment.