RtEvent.hpp

//
//  Copyright PHOENIX CONTACT Electronics GmbH
//
#pragma once
#include "Arp/System/Core/Arp.h"
#include "Arp/System/Commons/Logging.h"
#include "Arp/Plc/Commons/Esm/RtEventManagerSharedData.hpp"
#include "boost/interprocess/sync/interprocess_semaphore.hpp"

namespace Arp { namespace Plc { namespace Commons { namespace Esm
{

class RtEvent : private Loggable<RtEvent>
{
public: // typedefs
    using Ptr = RtEventManagerSharedData::Ptr<RtEvent>;

public: // construction/destruction
    RtEvent(const String& nameArg);
    RtEvent(const RtEvent& arg) = delete;
    RtEvent& operator=(const RtEvent& arg) = delete;
    ~RtEvent(void) = default;

protected:
    RtEvent(const String& nameArg, uint32 value);

public: // operators
    String GetName();
    void Set(void);
    bool SetAndWaitOne(unsigned long timeoutArg = 0);
    bool IsSubscriberReady(void);

    bool WaitOne(unsigned long timeoutArg = 0, bool setSubscriberReadyArg = true);
    void Done(void);
    void SetSubscriberReady(bool isSubscriberReadyArg);


private: // static fields
    String name;
    boost::interprocess::interprocess_semaphore semaphore1;
    boost::interprocess::interprocess_semaphore semaphore2;
    std::atomic<bool> isSubscriberReady;
};

// inline methods of class RtEvent

inline String RtEvent::GetName()
{
    return this->name;
}

inline void RtEvent::SetSubscriberReady(bool isSubscriberReadyArg)
{
    this->isSubscriberReady = isSubscriberReadyArg;
}

inline bool RtEvent::IsSubscriberReady(void)
{
    return this->isSubscriberReady;
}

}}}} // end of namespace Arp::Plc::Commons::Esm