event.hpp

Go to the documentation of this file.

#ifndef KOKKOS_EXECUTION_IMPL_HIP_EVENT_HPP
#define KOKKOS_EXECUTION_IMPL_HIP_EVENT_HPP
 
#include "Kokkos_Core.hpp"

 
namespace Kokkos::Execution::Impl {
 
template <>
struct SupportEvents<Kokkos::HIP> : std::true_type { };
 
template <>
struct Event<Kokkos::HIP> {
    hipEvent_t m_event = nullptr;
    uint64_t m_event_id = invalid_event_id;
 
    Event() = default;
 
    explicit Event(const Kokkos::HIP& exec) {
        record(exec);
    }
 
    Event(const Event&) = delete;
    Event& operator=(const Event&) = delete;
    Event(Event&& other) noexcept
        : m_event(std::exchange(other.m_event, nullptr))
        , m_event_id(std::exchange(other.m_event_id, invalid_event_id)) {
    }
    Event& operator=(Event&& other) noexcept {
        if (this != &other) {
            if (m_event != nullptr) {
                KOKKOS_IMPL_HIP_SAFE_CALL(hipEventDestroy(m_event));
            }
            m_event = std::exchange(other.m_event, nullptr);
            m_event_id = std::exchange(other.m_event_id, invalid_event_id);
        }
        return *this;
    }
 
    ~Event() {
        if (m_event != nullptr)
            KOKKOS_IMPL_HIP_SAFE_CALL(hipEventDestroy(m_event));
    }
 
    void record(const Kokkos::HIP& exec) {
        if (m_event == nullptr) {
            KOKKOS_IMPL_HIP_SAFE_CALL(hipEventCreateWithFlags(&m_event, hipEventDisableTiming));
        }
        KOKKOS_IMPL_HIP_SAFE_CALL(hipEventRecord(m_event, exec.hip_stream()));
        record_event(exec, m_event_id);
    }
 
    void wait() const {
        wait_event(m_event_id);
        if (hipEventQuery(m_event) != hipSuccess) {
            KOKKOS_IMPL_HIP_SAFE_CALL(hipEventSynchronize(m_event));
        }
    }
};
 
Event(const Kokkos::HIP&) -> Event<Kokkos::HIP>;
 
} // namespace Kokkos::Execution::Impl
 
#endif // KOKKOS_EXECUTION_IMPL_HIP_EVENT_HPP