serverChannelImpl.h

 
#ifndef SERVERCHANNEL_H_
#define SERVERCHANNEL_H_
 
#include <pv/destroyable.h>
#include <pv/remote.h>
#include <pv/security.h>
#include <pv/baseChannelRequester.h>
 
namespace epics {
namespace pvAccess {
 
class BaseChannelRequester;
 
class ServerChannel
{
public:
    POINTER_DEFINITIONS(ServerChannel);
 
    static size_t num_instances;

    ServerChannel(Channel::shared_pointer const & channel,
                      const ChannelRequester::shared_pointer& requester,
                      pvAccessID cid, pvAccessID sid);
    ~ServerChannel();
 
    const Channel::shared_pointer& getChannel() const { return _channel; }
 
    pvAccessID getCID() const { return _cid; }
 
    pvAccessID getSID() const { return _sid; }
 
    void registerRequest(pvAccessID id, const std::tr1::shared_ptr<BaseChannelRequester>& request);
 
    void unregisterRequest(pvAccessID id);
 
    void installGetField(const GetFieldRequester::shared_pointer& gf);
    void completeGetField(GetFieldRequester *req);

    std::tr1::shared_ptr<BaseChannelRequester> getRequest(pvAccessID id);
 
    void destroy();
 
    void printInfo() const;
 
    void printInfo(FILE *fd) const;
private:
    const Channel::shared_pointer _channel;
 
    const ChannelRequester::shared_pointer _requester;
 
    const pvAccessID _cid, _sid;

    GetFieldRequester::shared_pointer _active_requester;
 
    typedef std::map<pvAccessID, std::tr1::shared_ptr<BaseChannelRequester> > _requests_t;
    _requests_t _requests;
 
    bool _destroyed;
 
    mutable epics::pvData::Mutex _mutex;
};
 
}
}
 
 
#endif /* SERVERCHANNEL_H_ */