epics::pvAccess::ServerCreateChannelHandler Class Reference

#include "responseHandlers.h"

Inheritance diagram for epics::pvAccess::ServerCreateChannelHandler:

Collaboration diagram for epics::pvAccess::ServerCreateChannelHandler:

Public Member Functions
	ServerCreateChannelHandler (ServerContextImpl::shared_pointer const &context)
virtual	~ServerCreateChannelHandler ()
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

Create channel request handler.

Definition at line 176 of file responseHandlers.h.

Constructor & Destructor Documentation

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

inline

Definition at line 179 of file responseHandlers.h.

        :AbstractServerResponseHandler(context, "Create channel request")
    {}

virtual epics::pvAccess::ServerCreateChannelHandler::~ServerCreateChannelHandler ( )

inlinevirtual

Definition at line 182 of file responseHandlers.h.

{}

Member Function Documentation

void epics::pvAccess::ServerCreateChannelHandler::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 725 of file responseHandlers.cpp.

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

    // TODO for not only one request at the time is supported, i.e. dataCount == 1
    transport->ensureData((sizeof(int32)+sizeof(int16))/sizeof(int8));
    const int16 count = payloadBuffer->getShort();
    if (count != 1)
    {
        THROW_BASE_EXCEPTION("only 1 supported for now");
    }
    const pvAccessID cid = payloadBuffer->getInt();

    string channelName = SerializeHelper::deserializeString(payloadBuffer, transport.get());
    if (channelName.size() == 0)
    {
        LOG(logLevelDebug,"Zero length channel name, disconnecting client: %s", transport->getRemoteName().c_str());
        disconnect(transport);
        return;
    }
    else if (channelName.size() > MAX_CHANNEL_NAME_LENGTH)
    {
        LOG(logLevelDebug,"Unreasonable channel name length, disconnecting client: %s", transport->getRemoteName().c_str());
        disconnect(transport);
        return;
    }

    if (channelName == SERVER_CHANNEL_NAME)
    {
        // TODO singleton!!!
        ServerRPCService::shared_pointer serverRPCService(new ServerRPCService(_context));

        // TODO use std::make_shared
        std::tr1::shared_ptr<ServerChannelRequesterImpl> tp(new ServerChannelRequesterImpl(transport, channelName, cid));
        ChannelRequester::shared_pointer cr = tp;
        Channel::shared_pointer serverChannel = createRPCChannel(ChannelProvider::shared_pointer(), channelName, cr, serverRPCService);
        cr->channelCreated(Status::Ok, serverChannel);
    }
    else
    {
        const std::vector<ChannelProvider::shared_pointer>& _providers(_context->getChannelProviders());
        ServerContextImpl::s_channelNameToProvider_t::const_iterator it;

        if (_providers.size() == 1)
            ServerChannelRequesterImpl::create(_providers[0], transport, channelName, cid);
        else {
            ChannelProvider::shared_pointer prov;
            {
                Lock L(_context->_mutex);
                if((it = _context->s_channelNameToProvider.find(channelName)) != _context->s_channelNameToProvider.end())
                    prov = it->second.lock();
            }
            if(prov)
                ServerChannelRequesterImpl::create(prov, transport, channelName, cid);
        }
    }
}

---

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

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