Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
Tonny-Gu committed Mar 11, 2022
1 parent bd2c3d7 commit c58a495
Show file tree
Hide file tree
Showing 4 changed files with 7 additions and 1 deletion.
2 changes: 1 addition & 1 deletion include/raf/communicator.h
Original file line number Diff line number Diff line change
Expand Up @@ -146,7 +146,7 @@ class CommunicatorPool {
comm_.clear();
}

public:
private:
std::map<CommunicatorID, Communicator> comm_;
};

Expand Down
2 changes: 2 additions & 0 deletions src/distributed/common/communicator.cc
Original file line number Diff line number Diff line change
Expand Up @@ -121,6 +121,8 @@ RAF_REGISTER_GLOBAL("raf.distributed.RemoveCommunicator").set_body_typed([]() {
CommunicatorPool::Get()->Remove();
});

RAF_REGISTER_OBJECT_REFLECT(VoidCommunicatorObj);

} // namespace communicator
} // namespace distributed
} // namespace raf
2 changes: 2 additions & 0 deletions src/distributed/cuda/mpi_communicator.cc
Original file line number Diff line number Diff line change
Expand Up @@ -62,6 +62,8 @@ MPICommunicator MPICommunicator::make(Value rank_list) {

RAF_REGISTER_GLOBAL("raf.distributed.communicator._make.mpi").set_body_typed(MPICommunicator::make);

RAF_REGISTER_OBJECT_REFLECT(MPICommunicatorObj);

} // namespace communicator
} // namespace distributed
} // namespace raf
2 changes: 2 additions & 0 deletions src/distributed/cuda/nccl_communicator.cc
Original file line number Diff line number Diff line change
Expand Up @@ -79,6 +79,8 @@ NCCLCommunicator NCCLCommunicator::make(Value rank_list) {
RAF_REGISTER_GLOBAL("raf.distributed.communicator._make.nccl")
.set_body_typed(NCCLCommunicator::make);

RAF_REGISTER_OBJECT_REFLECT(NCCLCommunicatorObj);

} // namespace communicator
} // namespace distributed
} // namespace raf

0 comments on commit c58a495

Please sign in to comment.