beaconHandler.h

#ifndef BEACONHANDLER_H
#define BEACONHANDLER_H

#ifdef epicsExportSharedSymbols
#   define beaconHandlerEpicsExportSharedSymbols
#   undef epicsExportSharedSymbols
#endif

#include <osiSock.h>

#include <pv/timeStamp.h>
#include <pv/lock.h>

#ifdef beaconHandlerEpicsExportSharedSymbols
#   define epicsExportSharedSymbols
#       undef beaconHandlerEpicsExportSharedSymbols
#endif

#include <pv/pvaDefs.h>
#include <pv/remote.h>
#include <pv/pvAccess.h>

namespace epics {
namespace pvAccess {

class BeaconHandler
{
public:
    POINTER_DEFINITIONS(BeaconHandler);

    BeaconHandler(Context::shared_pointer const & context,
                  const osiSockAddr* responseFrom);

    virtual ~BeaconHandler();

    void beaconNotify(osiSockAddr* from,
                      epics::pvData::int8 remoteTransportRevision,
                      epics::pvData::TimeStamp* timestamp,
                      ServerGUID const &guid,
                      epics::pvData::int16 sequentalID,
                      epics::pvData::int16 changeCount,
                      const epics::pvData::PVFieldPtr& data);
private:
    Context::weak_pointer _context;
    epics::pvData::Mutex _mutex;
    ServerGUID _serverGUID;
    epics::pvData::int16 _serverChangeCount;
    bool _first;

    bool updateBeacon(epics::pvData::int8 remoteTransportRevision,
                      epics::pvData::TimeStamp* timestamp,
                      ServerGUID const &guid,
                      epics::pvData::int16 sequentalID,
                      epics::pvData::int16 changeCount);
};

}
}

#endif  /* INTROSPECTIONREGISTRY_H */