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"
#include <atomic>
 
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 timeout = 0);
    bool IsSubscriberReady(void);
 
    bool WaitOne(unsigned long timeout = 0, bool setSubscriberReady = true);
    void Done(void);
    void SetSubscriberReady(bool isSubscriberReadyArg);
 
private: // 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