thrust_allocator_adaptor.hpp

Go to the documentation of this file.

/*
 * SPDX-FileCopyrightText: Copyright (c) 2019-2026, NVIDIA CORPORATION.
 * SPDX-License-Identifier: Apache-2.0
 */
 
#pragma once
 
#include <rmm/cuda_device.hpp>
#include <rmm/detail/exec_check_disable.hpp>
#include <rmm/detail/export.hpp>
#include <rmm/detail/thrust_namespace.h>
#include <rmm/mr/per_device_resource.hpp>
#include <rmm/resource_ref.hpp>
 
#include <thrust/device_malloc_allocator.h>
#include <thrust/device_ptr.h>
#include <thrust/memory.h>
 
namespace RMM_NAMESPACE {
namespace mr {
template <typename T>
class thrust_allocator : public thrust::device_malloc_allocator<T> {
 public:
  using Base      = thrust::device_malloc_allocator<T>;  
  using pointer   = typename Base::pointer;              
  using size_type = typename Base::size_type;            
 
  template <typename U>
  struct rebind {
    using other = thrust_allocator<U>;  
  };
 
  RMM_EXEC_CHECK_DISABLE
  thrust_allocator() {}
 
  RMM_EXEC_CHECK_DISABLE
  explicit thrust_allocator(cuda_stream_view stream) : _stream{stream} {}
 
  RMM_EXEC_CHECK_DISABLE
  thrust_allocator(cuda_stream_view stream, rmm::device_async_resource_ref mr)
    : _stream{stream}, _mr(mr)
  {
  }
 
  RMM_EXEC_CHECK_DISABLE
  thrust_allocator(thrust_allocator const& other)
    : Base(other), _stream{other._stream}, _mr(other._mr), _device{other._device}
  {
  }
 
  RMM_EXEC_CHECK_DISABLE
  thrust_allocator(thrust_allocator&& other) noexcept
    : Base(std::move(other)),
      _stream{other._stream},
      _mr(std::move(other._mr)),
      _device{other._device}
  {
  }
 
  thrust_allocator& operator=(thrust_allocator const&) = default;
  thrust_allocator& operator=(thrust_allocator&&) noexcept = default;
 
  RMM_EXEC_CHECK_DISABLE
  template <typename U>
  thrust_allocator(thrust_allocator<U> const& other)
    : _mr(other.resource()), _stream{other.stream()}, _device{other._device}
  {
  }
 
  pointer allocate(size_type num)
  {
    cuda_set_device_raii dev{_device};
    return thrust::device_pointer_cast(static_cast<T*>(_mr.allocate(_stream, num * sizeof(T))));
  }
 
  void deallocate(pointer ptr, size_type num) noexcept
  {
    cuda_set_device_raii dev{_device};
    return _mr.deallocate(_stream, thrust::raw_pointer_cast(ptr), num * sizeof(T));
  }
 
  [[nodiscard]] rmm::device_async_resource_ref get_upstream_resource() const noexcept
  {
    return _mr;
  }
 
  [[nodiscard]] cuda_stream_view stream() const noexcept { return _stream; }
 
  friend void get_property(thrust_allocator const&, cuda::mr::device_accessible) noexcept {}
 
 private:
  cuda_stream_view _stream{};
  rmm::device_async_resource_ref _mr{rmm::mr::get_current_device_resource_ref()};
  cuda_device_id _device{get_current_cuda_device()};
};  // end of group
}  // namespace mr
}  // namespace RMM_NAMESPACE