epics::pvAccess::BlockingTCPConnector Class Reference

#include "blockingTCP.h"

Public Member Functions
	POINTER_DEFINITIONS (BlockingTCPConnector)
	BlockingTCPConnector (Context::shared_pointer const &context, int receiveBufferSize, float beaconInterval)
Transport::shared_pointer	connect (std::tr1::shared_ptr< ClientChannelImpl > const &client, ResponseHandler::shared_pointer const &responseHandler, osiSockAddr &address, epics::pvData::int8 transportRevision, epics::pvData::int16 priority)

Detailed Description

Channel Access TCP connector.

Author

Matej Sekoranja

Version

Id

BlockingTCPConnector.java,v 1.1 2010/05/03 14:45:47 mrkraimer Exp

Definition at line 51 of file blockingTCP.h.

Constructor & Destructor Documentation

epics::pvAccess::BlockingTCPConnector::BlockingTCPConnector	(	Context::shared_pointer const &	context,
		int	receiveBufferSize,
		float	beaconInterval
	)

Definition at line 24 of file blockingTCPConnector.cpp.

                             :
    _context(context),
    _receiveBufferSize(receiveBufferSize),
    _heartbeatInterval(heartbeatInterval)
{
}

Member Function Documentation

Transport::shared_pointer epics::pvAccess::BlockingTCPConnector::connect	(	std::tr1::shared_ptr< ClientChannelImpl > const &	client,
		ResponseHandler::shared_pointer const &	responseHandler,
		osiSockAddr &	address,
		epics::pvData::int8	transportRevision,
		epics::pvData::int16	priority
	)

Definition at line 72 of file blockingTCPConnector.cpp.

                                                {

    SOCKET socket = INVALID_SOCKET;

    char ipAddrStr[24];
    ipAddrToDottedIP(&address.ia, ipAddrStr, sizeof(ipAddrStr));

    Context::shared_pointer context = _context.lock();

    TransportRegistry::Reservation rsvp(context->getTransportRegistry(),
                                        address, priority);
    // we are now blocking any connect() to this destination (address and prio)
    // concurrent connect() to other destination is allowed.
    // This prevents us from opening duplicate connections.

    Transport::shared_pointer transport = context->getTransportRegistry()->get(address, priority);
    if(transport.get()) {
        LOG(logLevelDebug,
            "Reusing existing connection to PVA server: %s.",
            ipAddrStr);
        if (transport->acquire(client))
            return transport;
    }

    try {
        LOG(logLevelDebug, "Connecting to PVA server: %s.", ipAddrStr);

        socket = tryConnect(address, 3);

        LOG(logLevelDebug, "Socket connected to PVA server: %s.", ipAddrStr);

        // enable TCP_NODELAY (disable Nagle's algorithm)
        int optval = 1; // true
        int retval = ::setsockopt(socket, IPPROTO_TCP, TCP_NODELAY,
                                  (char *)&optval, sizeof(int));
        if(retval<0) {
            char errStr[64];
            epicsSocketConvertErrnoToString(errStr, sizeof(errStr));
            LOG(logLevelWarn, "Error setting TCP_NODELAY: %s.", errStr);
        }

        // enable TCP_KEEPALIVE
        retval = ::setsockopt(socket, SOL_SOCKET, SO_KEEPALIVE,
                              (char *)&optval, sizeof(int));
        if(retval<0)
        {
            char errStr[64];
            epicsSocketConvertErrnoToString(errStr, sizeof(errStr));
            LOG(logLevelWarn, "Error setting SO_KEEPALIVE: %s.", errStr);
        }

        // TODO tune buffer sizes?! Win32 defaults are 8k, which is OK

        // create transport
        // TODO introduce factory
        // get TCP send buffer size
        osiSocklen_t intLen = sizeof(int);
        int _socketSendBufferSize;
        retval = getsockopt(socket, SOL_SOCKET, SO_SNDBUF, (char *)&_socketSendBufferSize, &intLen);
        if(retval<0) {
            char strBuffer[64];
            epicsSocketConvertErrnoToString(strBuffer, sizeof(strBuffer));
            LOG(logLevelDebug, "Error getting SO_SNDBUF: %s.", strBuffer);
        }

        // create() also adds to context connection pool _context->getTransportRegistry()
        transport = detail::BlockingClientTCPTransportCodec::create(
                    context, socket, responseHandler, _receiveBufferSize, _socketSendBufferSize,
                    client, transportRevision, _heartbeatInterval, priority);

        // verify
        if(!transport->verify(5000)) {
            LOG(
                        logLevelDebug,
                        "Connection to PVA server %s failed to be validated, closing it.",
                        ipAddrStr);

            std::ostringstream temp;
            temp<<"Failed to verify TCP connection to '"<<ipAddrStr<<"'.";
            THROW_BASE_EXCEPTION(temp.str().c_str());
        }

        LOG(logLevelDebug, "Connected to PVA server: %s.", ipAddrStr);

        return transport;
    } catch(std::exception&) {
        if(transport.get())
            transport->close();
        else if(socket!=INVALID_SOCKET)
            epicsSocketDestroy(socket);
        throw;
    }
}

epics::pvAccess::BlockingTCPConnector::POINTER_DEFINITIONS

(

BlockingTCPConnector

)

---

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

• modules/pvAccess/src/remote/pv/blockingTCP.h
• modules/pvAccess/src/remote/blockingTCPConnector.cpp