SignalInformationQueue.hpp

Go to the documentation of this file.

#ifndef INCLUDE_DISTORTOS_INTERNAL_SYNCHRONIZATION_SIGNALINFORMATIONQUEUE_HPP_
#define INCLUDE_DISTORTOS_INTERNAL_SYNCHRONIZATION_SIGNALINFORMATIONQUEUE_HPP_

#include "distortos/distortosConfiguration.h"

#if DISTORTOS_SIGNALS_ENABLE == 1

#include "distortos/SignalInformation.hpp"

#include "estd/IntrusiveForwardList.hpp"

#include <memory>

namespace distortos
{

class SignalSet;

namespace internal
{

class SignalInformationQueue
{
public:

    struct QueueNode
    {
        estd::IntrusiveForwardListNode node;

        SignalInformation signalInformation;
    };

    using Storage = typename std::aligned_storage<sizeof(QueueNode), alignof(QueueNode)>::type;

    using StorageUniquePointer = std::unique_ptr<Storage[], void(&)(Storage*)>;

    SignalInformationQueue(StorageUniquePointer&& storageUniquePointer, size_t maxElements);

    ~SignalInformationQueue();

    std::pair<int, SignalInformation> acceptQueuedSignal(uint8_t signalNumber);

    bool canQueueSignal() const
    {
        return freeSignalInformationList_.empty() == false;
    }

    SignalSet getQueuedSignalSet() const;

    int queueSignal(uint8_t signalNumber, sigval value);

    SignalInformationQueue(const SignalInformationQueue&) = delete;
    SignalInformationQueue(SignalInformationQueue&&) = default;
    const SignalInformationQueue& operator=(const SignalInformationQueue&) = delete;
    SignalInformationQueue& operator=(SignalInformationQueue&&) = delete;

private:

    using List = estd::IntrusiveForwardList<QueueNode, &QueueNode::node>;

    StorageUniquePointer storageUniquePointer_;

    List signalInformationList_;

    List freeSignalInformationList_;
};

}   // namespace internal

}   // namespace distortos

#endif  // DISTORTOS_SIGNALS_ENABLE == 1

#endif  // INCLUDE_DISTORTOS_INTERNAL_SYNCHRONIZATION_SIGNALINFORMATIONQUEUE_HPP_