Skip to content

Commit

Permalink
fix number of things
Browse files Browse the repository at this point in the history
  • Loading branch information
viclafargue committed Sep 18, 2024
1 parent ea6b160 commit 1892f0a
Show file tree
Hide file tree
Showing 2 changed files with 7 additions and 8 deletions.
2 changes: 1 addition & 1 deletion cpp/include/raft/core/device_resources.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -124,7 +124,7 @@ class device_resources : public resources {

rmm::exec_policy_nosync& get_thrust_policy() const { return resource::get_thrust_policy(*this); }

raft::comms::nccl_clique get_nccl_clique_handle() const
const raft::comms::nccl_clique& get_nccl_clique_handle() const
{
return resource::get_nccl_clique_handle(*this);
}
Expand Down
13 changes: 6 additions & 7 deletions cpp/include/raft/core/resource/nccl_clique_handle.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -25,12 +25,12 @@ namespace raft::resource {

class nccl_clique_resource : public resource {
public:
nccl_clique_resource() : clique_() {}
~nccl_clique_resource() noexcept override {}
void* get_resource() override { return &clique_; }
nccl_clique_resource() : clique_(std::make_unique<raft::comms::nccl_clique>()) {}
~nccl_clique_resource() override {}
void* get_resource() override { return clique_.get(); }

private:
raft::comms::nccl_clique clique_;
std::unique_ptr<raft::comms::nccl_clique> clique_;
};

/** Factory that knows how to construct a specific raft::resource to populate the res_t. */
Expand All @@ -51,13 +51,12 @@ class nccl_clique_resource_factory : public resource_factory {
* @param[in] res the raft resources object
* @return NCCL clique
*/
inline raft::comms::nccl_clique get_nccl_clique_handle(resources const& res)
inline const raft::comms::nccl_clique& get_nccl_clique_handle(resources const& res)
{
if (!res.has_resource_factory(resource_type::NCCL_CLIQUE)) {
res.add_resource_factory(std::make_shared<nccl_clique_resource_factory>());
}
auto ret = *res.get_resource<raft::comms::nccl_clique>(resource_type::NCCL_CLIQUE);
return ret;
return *res.get_resource<raft::comms::nccl_clique>(resource_type::NCCL_CLIQUE);
};

/**
Expand Down

0 comments on commit 1892f0a

Please sign in to comment.