serverContextImpl.h

#ifndef SERVERCONTEXTIMPL_H
#define SERVERCONTEXTIMPL_H
 
#ifdef epicsExportSharedSymbols
#   define serverContextImplEpicsExportSharedSymbols
#   undef epicsExportSharedSymbols
#endif
 
#include <pv/thread.h>
 
#ifdef serverContextImplEpicsExportSharedSymbols
#   define epicsExportSharedSymbols
#       undef serverContextImplEpicsExportSharedSymbols
#endif
 
#include <pv/blockingUDP.h>
#include <pv/blockingTCP.h>
#include <pv/beaconEmitter.h>
 
#include "serverContext.h"
 
namespace epics {
namespace pvAccess {
 
class ServerContextImpl :
    public ServerContext,
    public Context,
    public std::tr1::enable_shared_from_this<ServerContextImpl>
{
    friend class ServerContext;
public:
    typedef std::tr1::shared_ptr<ServerContextImpl> shared_pointer;
    typedef std::tr1::shared_ptr<const ServerContextImpl> const_shared_pointer;
 
    static size_t num_instances;
 
    ServerContextImpl();
    virtual ~ServerContextImpl();
 
    //**************** derived from ServerContext ****************//
    const ServerGUID& getGUID() OVERRIDE FINAL;
    const Version& getVersion() OVERRIDE FINAL;
    void initialize();
    void run(epics::pvData::uint32 seconds) OVERRIDE FINAL;
    void shutdown() OVERRIDE FINAL;
    void printInfo(std::ostream& str, int lvl) OVERRIDE FINAL;
    void setBeaconServerStatusProvider(BeaconServerStatusProvider::shared_pointer const & beaconServerStatusProvider) OVERRIDE FINAL;
    //**************** derived from Context ****************//
    epics::pvData::Timer::shared_pointer getTimer() OVERRIDE FINAL;
    Channel::shared_pointer getChannel(pvAccessID id) OVERRIDE FINAL;
    Transport::shared_pointer getSearchTransport() OVERRIDE FINAL;
    Configuration::const_shared_pointer getConfiguration() OVERRIDE FINAL;
    TransportRegistry* getTransportRegistry() OVERRIDE FINAL;
 
    virtual void newServerDetected() OVERRIDE FINAL;
 
 
    epicsTimeStamp& getStartTime() OVERRIDE FINAL;
 
    virtual Configuration::shared_pointer getCurrentConfig() OVERRIDE FINAL;
 
    static const Version VERSION;
 
    float getBeaconPeriod();
 
    epics::pvData::int32 getReceiveBufferSize();
 
    epics::pvData::int32 getServerPort() OVERRIDE FINAL;
 
    epics::pvData::int32 getBroadcastPort() OVERRIDE FINAL;
 
    BeaconServerStatusProvider::shared_pointer getBeaconServerStatusProvider();
 
    const osiSockAddr *getServerInetAddress();
 
    const BlockingUDPTransport::shared_pointer& getBroadcastTransport();
 
    virtual const std::vector<ChannelProvider::shared_pointer>& getChannelProviders() OVERRIDE FINAL;
 
    bool isChannelProviderNamePreconfigured();
 
    // used by ServerChannelFindRequesterImpl
    typedef std::map<std::string, std::tr1::weak_ptr<ChannelProvider> > s_channelNameToProvider_t;
    s_channelNameToProvider_t s_channelNameToProvider;
private:
 
    ServerGUID _guid;
 
    std::string _beaconAddressList;
 
    IfaceNodeVector _ifaceList;
 
    osiSockAddr _ifaceAddr;
 
    std::string _ignoreAddressList;
 
    bool _autoBeaconAddressList;
 
    float _beaconPeriod;
 
    epics::pvData::int32 _broadcastPort;
 
    epics::pvData::int32 _serverPort;
 
    epics::pvData::int32 _receiveBufferSize;
 
    epics::pvData::Timer::shared_pointer _timer;
 
    BlockingUDPTransportVector _udpTransports;
 
    BlockingUDPTransport::shared_pointer _broadcastTransport;
 
    BeaconEmitter::shared_pointer _beaconEmitter;
 
    BlockingTCPAcceptor::shared_pointer _acceptor;
 
    TransportRegistry _transportRegistry;
 
    ResponseHandler::shared_pointer _responseHandler;
 
    // const after loadConfiguration()
    std::vector<ChannelProvider::shared_pointer> _channelProviders;
 
public:
    epics::pvData::Mutex _mutex;
private:
 
    epics::pvData::Event _runEvent;
 
    BeaconServerStatusProvider::shared_pointer _beaconServerStatusProvider;
 
    void generateGUID();
 
    void loadConfiguration();
 
    Configuration::const_shared_pointer configuration;
 
    epicsTimeStamp _startTime;
};
 
}
}
 
#endif // SERVERCONTEXTIMPL_H