baseChannelRequester.h

Go to the documentation of this file.

#ifndef BASECHANNELREQUESTER_H_
#define BASECHANNELREQUESTER_H_

#include <pv/requester.h>
#include <pv/destroyable.h>
#include <pv/serverContextImpl.h>
#include <pv/serverChannelImpl.h>

namespace epics {
namespace pvAccess {

class ServerChannel;
class ChannelRequest;

class BaseChannelRequester :
        virtual public epics::pvData::Requester,
        public TransportSender,
        public NetStats,
        public Destroyable
{
public:
    POINTER_DEFINITIONS(BaseChannelRequester);
    BaseChannelRequester(ServerContextImpl::shared_pointer const & context, std::tr1::shared_ptr<ServerChannel> const & channel,
                         const pvAccessID ioid, Transport::shared_pointer const & transport);
    virtual ~BaseChannelRequester() {};

    bool startRequest(epics::pvData::int32 qos);
    void stopRequest();
    epics::pvData::int32 getPendingRequest();
    virtual std::tr1::shared_ptr<ChannelRequest> getOperation() =0;
    virtual std::string getRequesterName() OVERRIDE FINAL;
    virtual void message(std::string const & message, epics::pvData::MessageType messageType) OVERRIDE FINAL;
    static void message(Transport::shared_pointer const & transport, const pvAccessID ioid, const std::string message, const epics::pvData::MessageType messageType);
    static void sendFailureMessage(const epics::pvData::int8 command, Transport::shared_pointer const & transport, const pvAccessID ioid, const epics::pvData::int8 qos, const epics::pvData::Status status);

    virtual void stats(Stats &s) const OVERRIDE FINAL;

    static const epics::pvData::Status okStatus;
    static const epics::pvData::Status badCIDStatus;
    static const epics::pvData::Status badIOIDStatus;
    static const epics::pvData::Status noReadACLStatus;
    static const epics::pvData::Status noWriteACLStatus;
    static const epics::pvData::Status noProcessACLStatus;
    static const epics::pvData::Status otherRequestPendingStatus;
    static const epics::pvData::Status notAChannelRequestStatus;
protected:
    const pvAccessID _ioid;
    const Transport::shared_pointer _transport;
    const std::tr1::shared_ptr<ServerChannel> _channel;
    epics::pvData::Mutex _mutex;
private:
    ServerContextImpl::shared_pointer _context;
    static const epics::pvData::int32 NULL_REQUEST;
    epics::pvData::int32 _pendingRequest;
};

class BaseChannelRequesterMessageTransportSender : public TransportSender
{
public:
    BaseChannelRequesterMessageTransportSender(const pvAccessID _ioid, const std::string message,const epics::pvData::MessageType messageType);
    virtual void send(epics::pvData::ByteBuffer* buffer, TransportSendControl* control) OVERRIDE FINAL;
private:
    const pvAccessID _ioid;
    const std::string _message;
    const epics::pvData::MessageType _messageType;
};

class BaseChannelRequesterFailureMessageTransportSender : public TransportSender
{
public:
    BaseChannelRequesterFailureMessageTransportSender(const epics::pvData::int8 command, Transport::shared_pointer const & transport, const pvAccessID ioid, const epics::pvData::int8 qos, const epics::pvData::Status& status);
    virtual void send(epics::pvData::ByteBuffer* buffer, TransportSendControl* control) OVERRIDE FINAL;

private:
    const epics::pvData::int8 _command;
    const pvAccessID _ioid;
    const epics::pvData::int8 _qos;
    const epics::pvData::Status _status;
    Transport::shared_pointer _transport;
};

}
}


#endif /* BASECHANNELREQUESTER_H_ */