beaconEmitter.h

 
#ifndef BEACONEMITTER_H
#define BEACONEMITTER_H
 
#ifdef epicsExportSharedSymbols
#   define beaconEmitterEpicsExportSharedSymbols
#   undef epicsExportSharedSymbols
#endif
 
#include <osiSock.h>
 
#include <pv/timer.h>
#include <pv/timeStamp.h>
#include <pv/sharedPtr.h>
 
#ifdef beaconEmitterEpicsExportSharedSymbols
#   define epicsExportSharedSymbols
#       undef beaconEmitterEpicsExportSharedSymbols
#endif
 
#include <pv/remote.h>
#include <pv/beaconServerStatusProvider.h>
//#include <pv/serverContext.h>
 
namespace epics {
namespace pvAccess {
 
class ServerContextImpl;
 
class BeaconEmitter:
    public TransportSender,
    public epics::pvData::TimerCallback,
    public std::tr1::enable_shared_from_this<BeaconEmitter>
{
public:
    typedef std::tr1::shared_ptr<BeaconEmitter> shared_pointer;
    typedef std::tr1::shared_ptr<const BeaconEmitter> const_shared_pointer;
 
//              BeaconEmitter(std::sting const & protocol,
//          Transport::shared_pointer const & transport, ServerContextImpl::shared_pointer const & context);
    BeaconEmitter(std::string const & protocol,
                  Transport::shared_pointer const & transport, std::tr1::shared_ptr<ServerContextImpl>& context);
 
    virtual ~BeaconEmitter();
 
    void send(epics::pvData::ByteBuffer* buffer, TransportSendControl* control);
 
    void timerStopped();
 
    void start();
 
    void reschedule();
 
    void callback();
 
    void destroy();
 
private:
 
    static const float EPICS_PVA_MIN_BEACON_PERIOD;
 
    static const float EPICS_PVA_MIN_BEACON_COUNT_LIMIT;
 
    const std::string _protocol;
 
    Transport::shared_pointer _transport;
 
    epics::pvData::int8 _beaconSequenceID;
 
    const ServerGUID _guid;
 
    const double _fastBeaconPeriod;
 
    const double _slowBeaconPeriod;
 
    const epics::pvData::int16 _beaconCountLimit;
 
    const osiSockAddr _serverAddress;
 
    const epics::pvData::int32 _serverPort;
 
    BeaconServerStatusProvider::shared_pointer _serverStatusProvider;
 
    epics::pvData::Timer::weak_pointer _timer;
};
 
}
}
 
#endif  /* BEACONEMITTER_H */