peak_event_controller.hpp

Go to the documentation of this file.

#pragma once


#include <peak/backend/peak_backend.h>
#include <peak/common/peak_common_structs.hpp>
#include <peak/common/peak_timeout.hpp>
#include <peak/dll_interface/peak_dll_interface_util.hpp>
#include <peak/event/peak_event.hpp>

#include <cstddef>
#include <cstdint>
#include <memory>


namespace peak
{
namespace core
{

class EventController
{
public:
    EventController() = delete;
    ~EventController();
    EventController(const EventController& other) = delete;
    EventController& operator=(const EventController& other) = delete;
    EventController(EventController&& other) = delete;
    EventController& operator=(EventController&& other) = delete;

    RawInformation Info(int32_t infoCommand) const;

    size_t NumEventsInQueue() const;

    uint64_t NumEventsFired() const;

    size_t EventMaxSize() const;

    size_t EventDataMaxSize() const;

    std::unique_ptr<Event> WaitForEvent(Timeout timeout_ms);

    void KillWait();

    void FlushEvents();

    EventType ControlledEventType() const;

private:
    friend ClassCreator<EventController>;
    explicit EventController(PEAK_EVENT_CONTROLLER_HANDLE eventControllerHandle);
    PEAK_EVENT_CONTROLLER_HANDLE m_backendHandle;
};

} /* namespace core */
} /* namespace peak */

/* Implementation */
namespace peak
{
namespace core
{

inline EventController::EventController(PEAK_EVENT_CONTROLLER_HANDLE eventControllerHandle)
    : m_backendHandle(eventControllerHandle)
{}

inline EventController::~EventController()
{
    (void)PEAK_C_ABI_PREFIX PEAK_EventController_Destruct(m_backendHandle);
}

inline RawInformation EventController::Info(int32_t infoCommand) const
{
    return QueryRawInformationFromCInterfaceFunction([&](int32_t* dataType, uint8_t* buffer, size_t* bufferSize) {
        return PEAK_C_ABI_PREFIX PEAK_EventController_GetInfo(
            m_backendHandle, infoCommand, dataType, buffer, bufferSize);
    });
}

inline size_t EventController::NumEventsInQueue() const
{
    return QueryNumericFromCInterfaceFunction<size_t>([&](size_t* numEventsInQueue) {
        return PEAK_C_ABI_PREFIX PEAK_EventController_GetNumEventsInQueue(m_backendHandle, numEventsInQueue);
    });
}

inline uint64_t EventController::NumEventsFired() const
{
    return QueryNumericFromCInterfaceFunction<uint64_t>([&](uint64_t* numEventsFired) {
        return PEAK_C_ABI_PREFIX PEAK_EventController_GetNumEventsFired(m_backendHandle, numEventsFired);
    });
}

inline size_t EventController::EventMaxSize() const
{
    return QueryNumericFromCInterfaceFunction<size_t>([&](size_t* eventMaxSize) {
        return PEAK_C_ABI_PREFIX PEAK_EventController_GetEventMaxSize(m_backendHandle, eventMaxSize);
    });
}

inline size_t EventController::EventDataMaxSize() const
{
    return QueryNumericFromCInterfaceFunction<size_t>([&](size_t* eventDataMaxSize) {
        return PEAK_C_ABI_PREFIX PEAK_EventController_GetEventDataMaxSize(m_backendHandle, eventDataMaxSize);
    });
}

inline std::unique_ptr<Event> EventController::WaitForEvent(Timeout timeout_ms)
{
    auto eventHandle = QueryNumericFromCInterfaceFunction<PEAK_EVENT_HANDLE>(
        [&](PEAK_EVENT_HANDLE* _eventHandle) {
            return PEAK_C_ABI_PREFIX PEAK_EventController_WaitForEvent(m_backendHandle, timeout_ms, _eventHandle);
        });

    return std::make_unique<ClassCreator<Event>>(eventHandle);
}

inline void EventController::KillWait()
{
    CallAndCheckCInterfaceFunction(
        [&] { return PEAK_C_ABI_PREFIX PEAK_EventController_KillWait(m_backendHandle); });
}

inline void EventController::FlushEvents()
{
    CallAndCheckCInterfaceFunction(
        [&] { return PEAK_C_ABI_PREFIX PEAK_EventController_FlushEvents(m_backendHandle); });
}

inline EventType EventController::ControlledEventType() const
{
    return static_cast<EventType>(
        QueryNumericFromCInterfaceFunction<PEAK_EVENT_TYPE>([&](PEAK_EVENT_TYPE* controlledEventType) {
            return PEAK_C_ABI_PREFIX PEAK_EventController_GetControlledEventType(
                m_backendHandle, controlledEventType);
        }));
}

} /* namespace core */
} /* namespace peak */