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 
{
    class InternalClientContextImpl;
}
 
namespace epics {
namespace pvAccess {
namespace detail {
    class BeaconCleanupHandler;
}

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;
    std::tr1::shared_ptr<detail::BeaconCleanupHandler> _callback;

    bool updateBeacon(epics::pvData::int8 remoteTransportRevision,
                      epics::pvData::TimeStamp* timestamp,
                      ServerGUID const &guid,
                      epics::pvData::int16 sequentalID,
                      epics::pvData::int16 changeCount);
 
    friend class ::InternalClientContextImpl;
};
 
}
}
 
#endif  /* INTROSPECTIONREGISTRY_H */