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 */