beaconEmitter.h

Go to the documentation of this file.

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