devicescratch.h

Go to the documentation of this file.

#ifndef TTG_PARSEC_DEVICESCRATCH_H
#define TTG_PARSEC_DEVICESCRATCH_H
 
// TODO: replace with short vector
#define TTG_PARSEC_MAX_NUM_DEVICES 4
 
#include <array>
#include <parsec.h>
#include <parsec/data_internal.h>
#include <parsec/mca/device/device.h>
#include <parsec/mca/device/device_gpu.h>
#include <ttg/devicescope.h>
#include "ttg/parsec/task.h"
 
namespace ttg_parsec {
 
namespace detail {
  // fwd decl
  template<typename T>
  parsec_data_t* get_parsec_data(const ttg_parsec::devicescratch<T>&);
} // namespace detail
 
template<typename T>
struct devicescratch {
 
  using element_type = std::decay_t<T>;
 
  static_assert(std::is_trivially_copyable_v<element_type>,
                "Only trivially copyable types are supported for devices.");
  static_assert(std::is_default_constructible_v<element_type>,
                "Only default constructible types are supported for devices.");
 
private:
 
  parsec_data_t* m_data = nullptr;
  ttg::scope m_scope;
 
  static parsec_data_t* create_parsec_data(void *ptr, size_t count) {
 
    parsec_data_t *data = parsec_data_create_with_type(nullptr, 0, ptr,
                                                       sizeof(element_type)*count,
                                                       parsec_datatype_int8_t);
    data->device_copies[0]->flags |= PARSEC_DATA_FLAG_PARSEC_MANAGED;
    data->device_copies[0]->coherency_state = PARSEC_DATA_COHERENCY_SHARED;
    return data;
  }
 
  friend parsec_data_t* detail::get_parsec_data<T>(const ttg_parsec::devicescratch<T>&);
 
public:
 
  /* Constructing a devicescratch using application-managed memory.
   * The memory pointed to by ptr must be accessible during
   * the life-time of the devicescratch. */
  devicescratch(element_type* ptr, ttg::scope scope = ttg::scope::SyncIn, std::size_t count = 1)
  : m_data(create_parsec_data(ptr, count))
  , m_scope(scope)
  {
    if (ttg::scope::SyncIn == scope) {
      /* increment the version to force the first initial transfer */
      m_data->device_copies[0]->version = 1;
    }
  }
 
  /* don't allow moving */
  devicescratch(devicescratch&&) = delete;
 
  /* don't allow copying */
  devicescratch(const devicescratch& db) = delete;
 
  /* don't allow moving */
  devicescratch& operator=(devicescratch&&) = delete;
 
  /* don't allow copying */
  devicescratch& operator=(const devicescratch& db) = delete;
 
  ~devicescratch() {
    /* remove data from flow */
    if (nullptr != m_data) {
      parsec_data_discard(m_data);
    }
    m_data = nullptr;
  }
 
  /* get the current device pointer */
  element_type* device_ptr() {
    assert(is_valid());
    return static_cast<element_type*>(m_data->device_copies[m_data->owner_device]->device_private);
  }
 
  /* get the current device pointer */
  const element_type* device_ptr() const {
    assert(is_valid());
    return static_cast<element_type*>(m_data->device_copies[m_data->owner_device]->device_private);
  }
 
  bool is_valid() const {
    // TODO: how to get the current device
    // return (m_data->owner_device == parsec_current_device);
    return true;
  }
 
  ttg::scope scope() const {
    return m_scope;
  }
 
  std::size_t size() const {
    return (m_data->nb_elts / sizeof(element_type));
  }
 
};
 
namespace detail {
  template<typename T>
  parsec_data_t* get_parsec_data(const ttg_parsec::devicescratch<T>& scratch) {
    return const_cast<parsec_data_t*>(scratch.m_data);
  }
} // namespace detail
 
} // namespace ttg_parsec
 
#endif // TTG_PARSEC_DEVICESCRATCH_H