repeaterClient Class Reference

#include "repeaterClient.h"

Inheritance diagram for repeaterClient:

Collaboration diagram for repeaterClient:

Public Member Functions
	repeaterClient (const osiSockAddr &from)
	~repeaterClient ()
bool	connect ()
bool	sendConfirm ()
bool	sendMessage (const void *pBuf, unsigned bufSize)
bool	verify ()
bool	identicalAddress (const osiSockAddr &from)
bool	identicalPort (const osiSockAddr &from)
void *	operator new (size_t size, tsFreeList< repeaterClient, 0x20 > &)
unsigned short	port () const
void	operator delete (void *)
Public Member Functions inherited from tsDLNode< repeaterClient >
	tsDLNode ()
	tsDLNode (const tsDLNode< repeaterClient > &)
const tsDLNode< repeaterClient > &	operator= (const tsDLNode< repeaterClient > &)

Public Attributes
epicsPlacementDeleteOperator((void *, tsFreeList< repeaterClient, 0x20 > &)) private SOCKE	sock )

Detailed Description

Definition at line 40 of file repeaterClient.h.

Constructor & Destructor Documentation

repeaterClient::repeaterClient

(

const osiSockAddr &

from

)

Definition at line 127 of file repeater.cpp.

                                                           :
    from ( fromIn ), sock ( INVALID_SOCKET )
{
#ifdef DEBUG
    unsigned port = ntohs ( from.ia.sin_port );
    debugPrintf ( ( "new client %u\n", port ) );
#endif
}

repeaterClient::~repeaterClient

(

)

Definition at line 218 of file repeater.cpp.

{
    if ( this->sock != INVALID_SOCKET ) {
        epicsSocketDestroy ( this->sock );
    }
#ifdef DEBUG
    epicsUInt16 port = ntohs ( this->from.ia.sin_port );
    debugPrintf ( ( "Deleted client %u\n", port ) );
#endif
}

Member Function Documentation

bool repeaterClient::connect

(

)

Definition at line 136 of file repeater.cpp.

{
    int status;

    if ( int sockerrno = makeSocket ( PORT_ANY, false, & this->sock ) ) {
        char sockErrBuf[64];
        epicsSocketConvertErrorToString (
            sockErrBuf, sizeof ( sockErrBuf ), sockerrno );
        fprintf ( stderr, "%s: no client sock because \"%s\"\n",
                __FILE__, sockErrBuf );
        return false;
    }

    status = ::connect ( this->sock, &this->from.sa, sizeof ( this->from.sa ) );
    if ( status < 0 ) {
        char sockErrBuf[64];
        epicsSocketConvertErrnoToString (
            sockErrBuf, sizeof ( sockErrBuf ) );
        fprintf ( stderr, "%s: unable to connect client sock because \"%s\"\n",
            __FILE__, sockErrBuf );
        return false;
    }

    return true;
}

bool repeaterClient::identicalAddress ( const osiSockAddr &  from )

inline

Definition at line 259 of file repeater.cpp.

{
    if ( fromIn.sa.sa_family == this->from.sa.sa_family ) {
        if ( fromIn.ia.sin_port == this->from.ia.sin_port) {
            if ( fromIn.ia.sin_addr.s_addr == this->from.ia.sin_addr.s_addr ) {
                return true;
            }
        }
    }
    return false;
}

bool repeaterClient::identicalPort ( const osiSockAddr &  from )

inline

Definition at line 271 of file repeater.cpp.

{
    if ( fromIn.sa.sa_family == this->from.sa.sa_family ) {
        if ( fromIn.ia.sin_port == this->from.ia.sin_port) {
            return true;
        }
    }
    return false;
}

void repeaterClient::operator delete

(

void *

)

Definition at line 229 of file repeater.cpp.

{
    // Visual C++ .net appears to require operator delete if
    // placement operator delete is defined? I smell a ms rat
    // because if I declare placement new and delete, but
    // comment out the placement delete definition there are
    // no undefined symbols.
    errlogPrintf ( "%s:%d this compiler is confused about placement delete - memory was probably leaked",
        __FILE__, __LINE__ );
}

void * repeaterClient::operator new	(	size_t	size,
		tsFreeList< repeaterClient, 0x20 > &	freeList
	)

Definition at line 240 of file repeater.cpp.

{
    return freeList.allocate ( size );
}

unsigned short repeaterClient::port ( ) const

inline

Definition at line 254 of file repeater.cpp.

{
    return ntohs ( this->from.ia.sin_port );
}

bool repeaterClient::sendConfirm

(

)

Definition at line 162 of file repeater.cpp.

{
    int status;

    caHdr confirm;
    memset ( (char *) &confirm, '\0', sizeof (confirm) );
    AlignedWireRef < epicsUInt16 > ( confirm.m_cmmd ) = REPEATER_CONFIRM;
    confirm.m_available = this->from.ia.sin_addr.s_addr;
    status = send ( this->sock, (char *) &confirm,
                    sizeof (confirm), 0 );
    if ( status >= 0 ) {
        assert ( status == sizeof ( confirm ) );
        return true;
    }
    else if ( SOCKERRNO == SOCK_ECONNREFUSED ) {
        return false;
    }
    else {
        char sockErrBuf[64];
        epicsSocketConvertErrnoToString (
            sockErrBuf, sizeof ( sockErrBuf ) );
        debugPrintf ( ( "CA Repeater: confirm req err was \"%s\"\n", sockErrBuf) );
        return false;
    }
}

bool repeaterClient::sendMessage	(	const void *	pBuf,
		unsigned	bufSize
	)

Definition at line 188 of file repeater.cpp.

{
    int status;

    status = send ( this->sock, (char *) pBuf, bufSize, 0 );
    if ( status >= 0 ) {
        assert ( static_cast <unsigned> ( status ) == bufSize );
#ifdef DEBUG
        epicsUInt16 port = ntohs ( this->from.ia.sin_port );
        debugPrintf ( ("Sent to %u\n", port ) );
#endif
        return true;
    }
    else {
        int errnoCpy = SOCKERRNO;
        if ( errnoCpy == SOCK_ECONNREFUSED ) {
#ifdef DEBUG
            epicsUInt16 port = ntohs ( this->from.ia.sin_port );
            debugPrintf ( ("Client refused message %u\n", port ) );
#endif
        }
        else {
            char sockErrBuf[64];
            epicsSocketConvertErrnoToString ( sockErrBuf, sizeof ( sockErrBuf ) );
            debugPrintf ( ( "CA Repeater: UDP send err was \"%s\"\n", sockErrBuf) );
        }
        return false;
    }
}

bool repeaterClient::verify

(

)

Definition at line 281 of file repeater.cpp.

{
    SOCKET tmpSock;
    int sockerrno = makeSocket ( this->port (), false, & tmpSock );

    if ( sockerrno == SOCK_EADDRINUSE ) {
        // Normal result, client using port
        return true;
    }

    if ( sockerrno == 0 ) {
        // Client went away, released port
        epicsSocketDestroy ( tmpSock );
    }
    else {
        char sockErrBuf[64];
        epicsSocketConvertErrorToString (
            sockErrBuf, sizeof ( sockErrBuf ), sockerrno );
        fprintf ( stderr, "CA Repeater: Bind test error \"%s\"\n",
            sockErrBuf );
    }
    return false;
}

Member Data Documentation

epicsPlacementDeleteOperator (( void *, tsFreeList < repeaterClient, 0x20 > & )) private SOCKE repeaterClient::sock)

Definition at line 52 of file repeaterClient.h.

---

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

• modules/ca/src/client/repeaterClient.h
• modules/ca/src/client/repeater.cpp