epics::pvAccess::BlockingTCPAcceptor Class Reference

#include "blockingTCP.h"

Inheritance diagram for epics::pvAccess::BlockingTCPAcceptor:

Collaboration diagram for epics::pvAccess::BlockingTCPAcceptor:

Public Member Functions
	POINTER_DEFINITIONS (BlockingTCPAcceptor)
	BlockingTCPAcceptor (Context::shared_pointer const &context, ResponseHandler::shared_pointer const &responseHandler, const osiSockAddr &addr, int receiveBufferSize)
virtual	~BlockingTCPAcceptor ()
const osiSockAddr *	getBindAddress ()
void	destroy ()

Detailed Description

Channel Access Server TCP acceptor.

Author

Matej Sekoranja

Version

Id

BlockingTCPAcceptor.java,v 1.1 2010/05/03 14:45:42 mrkraimer Exp

Definition at line 98 of file blockingTCP.h.

Constructor & Destructor Documentation

epics::pvAccess::BlockingTCPAcceptor::BlockingTCPAcceptor	(	Context::shared_pointer const &	context,
		ResponseHandler::shared_pointer const &	responseHandler,
		const osiSockAddr &	addr,
		int	receiveBufferSize
	)

Definition at line 26 of file blockingTCPAcceptor.cpp.

                                                        :
    _context(context),
    _responseHandler(responseHandler),
    _bindAddress(),
    _serverSocketChannel(INVALID_SOCKET),
    _receiveBufferSize(receiveBufferSize),
    _destroyed(false),
    _thread(*this, "TCP-acceptor",
            epicsThreadGetStackSize(
                epicsThreadStackBig),
            epicsThreadPriorityMedium)
{
    _bindAddress = addr;
    initialize();
}

epics::pvAccess::BlockingTCPAcceptor::~BlockingTCPAcceptor ( )

virtual

Definition at line 44 of file blockingTCPAcceptor.cpp.

                                          {
    destroy();
}

Member Function Documentation

void epics::pvAccess::BlockingTCPAcceptor::destroy

(

)

Destroy acceptor (stop listening).

Definition at line 231 of file blockingTCPAcceptor.cpp.

                                  {
    SOCKET sock;
    {
        Lock guard(_mutex);
        if(_destroyed) return;
        _destroyed = true;

        sock = _serverSocketChannel;
        _serverSocketChannel = INVALID_SOCKET;
    }

    if(sock!=INVALID_SOCKET) {
        char ipAddrStr[24];
        ipAddrToDottedIP(&_bindAddress.ia, ipAddrStr, sizeof(ipAddrStr));
        LOG(logLevelDebug, "Stopped accepting connections at %s.", ipAddrStr);

        switch(epicsSocketSystemCallInterruptMechanismQuery())
        {
        case esscimqi_socketBothShutdownRequired:
            shutdown(sock, SHUT_RDWR);
            epicsSocketDestroy(sock);
            _thread.exitWait();
            break;
        case esscimqi_socketSigAlarmRequired:
            LOG(logLevelError, "SigAlarm close not implemented for this target\n");
        case esscimqi_socketCloseRequired:
            epicsSocketDestroy(sock);
            _thread.exitWait();
            break;
        }
    }
}

const osiSockAddr* epics::pvAccess::BlockingTCPAcceptor::getBindAddress ( )

inline

Bind socket address.

Returns

bind socket address, null if not binded.

Definition at line 112 of file blockingTCP.h.

                                        {
        return &_bindAddress;
    }

epics::pvAccess::BlockingTCPAcceptor::POINTER_DEFINITIONS

(

BlockingTCPAcceptor

)

---

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

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