SignalsCatcherControlBlock.hpp

Go to the documentation of this file.

#ifndef INCLUDE_DISTORTOS_INTERNAL_SYNCHRONIZATION_SIGNALSCATCHERCONTROLBLOCK_HPP_
#define INCLUDE_DISTORTOS_INTERNAL_SYNCHRONIZATION_SIGNALSCATCHERCONTROLBLOCK_HPP_

#include "distortos/distortosConfiguration.h"

#if DISTORTOS_SIGNALS_ENABLE == 1

#include "distortos/SignalAction.hpp"

#include <memory>

namespace distortos
{

namespace internal
{

class SignalsReceiverControlBlock;
class ThreadControlBlock;

class SignalsCatcherControlBlock
{
public:

    using Association = std::pair<SignalSet, SignalAction>;

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

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

    SignalsCatcherControlBlock(StorageUniquePointer&& storageUniquePointer, size_t storageSize);

    ~SignalsCatcherControlBlock();

    void afterGenerateQueueUnlocked(ThreadControlBlock& threadControlBlock);

    int beforeGenerateQueue(ThreadControlBlock& threadControlBlock);

    void deliveryOfSignalsStartedHook()
    {
        deliveryIsPending_ = false;
    }

    std::pair<int, SignalAction> getAssociation(uint8_t signalNumber) const;

    SignalSet getSignalMask() const
    {
        return signalMask_;
    }

    std::pair<int, SignalAction> setAssociation(uint8_t signalNumber, const SignalAction& signalAction);

    void setSignalMask(SignalSet signalMask, const SignalsReceiverControlBlock* owner);

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

private:

    SignalAction clearAssociation(uint8_t signalNumber);

    SignalAction clearAssociation(uint8_t signalNumber, Association& association);

    Association* getAssociationsBegin() const
    {
        return reinterpret_cast<Association*>(storageUniquePointer_.get());
    }

    int requestDeliveryOfSignals(ThreadControlBlock& threadControlBlock);

    StorageUniquePointer storageUniquePointer_;

    SignalSet signalMask_;

    union
    {
        Association* associationsEnd_;

        Storage* storageBegin_;
    };

    Storage* storageEnd_;

    bool deliveryIsPending_;
};

}   // namespace internal

}   // namespace distortos

#endif  // DISTORTOS_SIGNALS_ENABLE == 1

#endif  // INCLUDE_DISTORTOS_INTERNAL_SYNCHRONIZATION_SIGNALSCATCHERCONTROLBLOCK_HPP_