epics::pvAccess::ServerConnectionValidationHandler Class Reference

#include "responseHandlers.h"

Inheritance diagram for epics::pvAccess::ServerConnectionValidationHandler:

Collaboration diagram for epics::pvAccess::ServerConnectionValidationHandler:

Public Member Functions
	ServerConnectionValidationHandler (ServerContextImpl::shared_pointer const &context)
virtual	~ServerConnectionValidationHandler ()
virtual void	handleResponse (osiSockAddr *responseFrom, Transport::shared_pointer const &transport, epics::pvData::int8 version, epics::pvData::int8 command, std::size_t payloadSize, epics::pvData::ByteBuffer *payloadBuffer) OVERRIDE FINAL
Public Member Functions inherited from epics::pvAccess::AbstractServerResponseHandler
	AbstractServerResponseHandler (ServerContextImpl::shared_pointer const &context, std::string description)
virtual	~AbstractServerResponseHandler ()
Public Member Functions inherited from epics::pvAccess::ResponseHandler
	POINTER_DEFINITIONS (ResponseHandler)
	ResponseHandler (Context *context, const std::string &description)
virtual	~ResponseHandler ()

Additional Inherited Members
Static Public Attributes inherited from epics::pvAccess::ResponseHandler
static size_t	num_instances
Protected Attributes inherited from epics::pvAccess::AbstractServerResponseHandler
ServerContextImpl::shared_pointer	_context
Protected Attributes inherited from epics::pvAccess::ResponseHandler
std::string	_description
epics::pvData::int32	_debugLevel

Detailed Description

Connection validation message handler.

Definition at line 56 of file responseHandlers.h.

Constructor & Destructor Documentation

epics::pvAccess::ServerConnectionValidationHandler::ServerConnectionValidationHandler ( ServerContextImpl::shared_pointer const &  context )

inline

Definition at line 58 of file responseHandlers.h.

                                                                                       :
        AbstractServerResponseHandler(context, "Connection validation") {
    }

virtual epics::pvAccess::ServerConnectionValidationHandler::~ServerConnectionValidationHandler ( )

inlinevirtual

Definition at line 61 of file responseHandlers.h.

{}

Member Function Documentation

void epics::pvAccess::ServerConnectionValidationHandler::handleResponse ( osiSockAddr *  responseFrom, Transport::shared_pointer const &  transport, epics::pvData::int8  version, epics::pvData::int8  command, std::size_t  payloadSize, epics::pvData::ByteBuffer *  payloadBuffer  )

virtual

Handle response.

Parameters

[in]	responseFrom	remote address of the responder, 0 if unknown.
[in]	transport	response source transport.
[in]	version	message version.
[in]	payloadSize	size of this message data available in the payloadBuffer.
[in]	payloadBuffer	message payload data. Note that this might not be the only message in the buffer. Code must not manipulate buffer.

Reimplemented from epics::pvAccess::ResponseHandler.

Definition at line 174 of file responseHandlers.cpp.

{
    AbstractServerResponseHandler::handleResponse(responseFrom,
            transport, version, command, payloadSize, payloadBuffer);

    transport->ensureData(4+2+2);
    transport->setRemoteTransportReceiveBufferSize(payloadBuffer->getInt());
    // TODO clientIntrospectionRegistryMaxSize
    /* int clientIntrospectionRegistryMaxSize = */ payloadBuffer->getShort();
    // TODO connectionQoS
    /* int16 connectionQoS = */ payloadBuffer->getShort();

    // authNZ
    std::string securityPluginName = SerializeHelper::deserializeString(payloadBuffer, transport.get());

    // optional authNZ plug-in initialization data
    PVStructure::shared_pointer data;
    if (payloadBuffer->getRemaining()) {
        PVField::shared_pointer raw(SerializationHelper::deserializeFull(payloadBuffer, transport.get()));
        if(raw && raw->getField()->getType()==structure) {
            data = std::tr1::static_pointer_cast<PVStructure>(raw);
        } else {
            // was originally allowed, but never used
        }
    }

    detail::BlockingServerTCPTransportCodec* casTransport(static_cast<detail::BlockingServerTCPTransportCodec*>(transport.get()));
    //TODO: simplify byzantine class heirarchy...
    assert(casTransport);

    try {
        casTransport->authNZInitialize(securityPluginName, data);
    }catch(std::exception& e){
        if (IS_LOGGABLE(logLevelDebug))
        {
            LOG(logLevelDebug, "Security plug-in '%s' failed to create a session for PVA client: %s.", securityPluginName.c_str(), casTransport->getRemoteName().c_str());
        }
        casTransport->verified(pvData::Status::error(e.what()));
        throw;
    }
}

---

The documentation for this class was generated from the following files:

• modules/pvAccess/src/server/pv/responseHandlers.h
• modules/pvAccess/src/server/responseHandlers.cpp