comQueRecv Class Reference

#include "comQueRecv.h"

Public Member Functions
	comQueRecv (comBufMemoryManager &)
	~comQueRecv ()
unsigned	occupiedBytes () const
unsigned	copyOutBytes (epicsInt8 *pBuf, unsigned nBytes)
unsigned	removeBytes (unsigned nBytes)
void	pushLastComBufReceived (comBuf &)
void	clear ()
bool	popOldMsgHeader (struct caHdrLargeArray &)
epicsInt8	popInt8 ()
epicsUInt8	popUInt8 ()
epicsInt16	popInt16 ()
epicsUInt16	popUInt16 ()
epicsInt32	popInt32 ()
epicsUInt32	popUInt32 ()
epicsFloat32	popFloat32 ()
epicsFloat64	popFloat64 ()
void	popString (epicsOldString *)

Detailed Description

Definition at line 30 of file comQueRecv.h.

Constructor & Destructor Documentation

comQueRecv::comQueRecv

(

comBufMemoryManager &

comBufMemoryManagerIn

)

Definition at line 28 of file comQueRecv.cpp.

                                                                    :
    comBufMemMgr ( comBufMemoryManagerIn ), nBytesPending ( 0u )
{
}

comQueRecv::~comQueRecv

(

)

Definition at line 33 of file comQueRecv.cpp.

{
    this->clear ();
}

Member Function Documentation

void comQueRecv::clear

(

)

Definition at line 38 of file comQueRecv.cpp.

{
    comBuf *pBuf;
    while ( ( pBuf = this->bufs.get () ) ) {
        pBuf->~comBuf ();
        this->comBufMemMgr.release ( pBuf );
    }
    this->nBytesPending = 0u;
}

unsigned comQueRecv::copyOutBytes	(	epicsInt8 *	pBuf,
		unsigned	nBytes
	)

Definition at line 48 of file comQueRecv.cpp.

{
    unsigned totalBytes = 0u;
    do {
        comBuf * pComBuf = this->bufs.first ();
        if ( ! pComBuf ) {
            this->nBytesPending -= totalBytes;
            return totalBytes;
        }
        totalBytes += pComBuf->copyOutBytes ( &pBuf[totalBytes], nBytes - totalBytes );
        if ( pComBuf->occupiedBytes () == 0u ) {
            this->bufs.remove ( *pComBuf );
            pComBuf->~comBuf ();
            this->comBufMemMgr.release ( pComBuf );
        }
    }
    while ( totalBytes < nBytes );
    this->nBytesPending -= totalBytes;
    return totalBytes;
}

unsigned comQueRecv::occupiedBytes ( ) const

inline

Definition at line 60 of file comQueRecv.h.

{
    return this->nBytesPending;
}

epicsFloat32 comQueRecv::popFloat32 ( )

inline

Definition at line 82 of file comQueRecv.h.

{
    union {
        epicsUInt8 _wire[ sizeof ( epicsFloat32 ) ];
        epicsFloat32 _fp;
    } tmp;
    // optimizer will unroll this loop
    for ( unsigned i = 0u; i < sizeof ( tmp._wire ); i++ ) {
        tmp._wire[i] = this->popUInt8 ();
    }
    return AlignedWireRef < epicsFloat32 > ( tmp._fp );
}

epicsFloat64 comQueRecv::popFloat64 ( )

inline

Definition at line 97 of file comQueRecv.h.

{
    union {
        epicsUInt8 _wire[ sizeof ( epicsFloat64 ) ];
        epicsFloat64 _fp;
    } tmp;
    // optimizer will unroll this loop
    for ( unsigned i = 0u; i < sizeof ( tmp._wire ); i++ ) {
        tmp._wire[i] = this->popUInt8 ();
    }
    return AlignedWireRef < epicsFloat64 > ( tmp._fp );
}

epicsInt16 comQueRecv::popInt16 ( )

inline

Definition at line 70 of file comQueRecv.h.

{
    return static_cast < epicsInt16 > ( this->popUInt16() );
}

epicsInt32 comQueRecv::popInt32 ( )

inline

Definition at line 75 of file comQueRecv.h.

{
    return static_cast < epicsInt32 > ( this->popUInt32() );
}

epicsInt8 comQueRecv::popInt8 ( )

inline

Definition at line 65 of file comQueRecv.h.

{
    return static_cast < epicsInt8 > ( this->popUInt8() );
}

bool comQueRecv::popOldMsgHeader

(

struct caHdrLargeArray &

msg

)

Definition at line 230 of file comQueRecv.cpp.

{
    // try first for all in one buffer efficent version
    comBuf * pComBuf = this->bufs.first ();
    if ( ! pComBuf ) {
        return false;
    }
    unsigned avail = pComBuf->occupiedBytes ();
    if ( avail >= sizeof ( caHdr ) ) {
        pComBuf->pop ( msg.m_cmmd );
        ca_uint16_t smallPostsize = 0;
        pComBuf->pop ( smallPostsize );
        msg.m_postsize = smallPostsize;
        pComBuf->pop ( msg.m_dataType );
        ca_uint16_t smallCount = 0;
        pComBuf->pop ( smallCount );
        msg.m_count = smallCount;
        pComBuf->pop ( msg.m_cid );
        pComBuf->pop ( msg.m_available );
        this->nBytesPending -= sizeof ( caHdr );
        if ( avail == sizeof ( caHdr ) ) {
            this->removeAndDestroyBuf ( *pComBuf );
        }
        return true;
    }
    else if ( this->occupiedBytes () >= sizeof ( caHdr ) ) {
        msg.m_cmmd = this->popUInt16 ();
        msg.m_postsize = this->popUInt16 ();
        msg.m_dataType = this->popUInt16 ();
        msg.m_count = this->popUInt16 ();
        msg.m_cid = this->popUInt32 ();
        msg.m_available = this->popUInt32 ();
        return true;
    }
    else {
        return false;
    }
}

void comQueRecv::popString

(

epicsOldString *

pStr

)

Definition at line 95 of file comQueRecv.cpp.

{
    for ( unsigned i = 0u; i < sizeof ( *pStr ); i++ ) {
        pStr[0][i] = this->popInt8 ();
    }
}

epicsUInt16 comQueRecv::popUInt16

(

)

Definition at line 192 of file comQueRecv.cpp.

{
    comBuf * pComBuf = this->bufs.first ();
    if ( ! pComBuf ) {
        comBuf::throwInsufficentBytesException ();
    }
    // try first for all in one buffer efficent version
    epicsUInt16 tmp = 0;
    comBuf::popStatus status = pComBuf->pop ( tmp );
    if ( status.success ) {
        this->nBytesPending -= sizeof ( epicsUInt16 );
        if ( status.nowEmpty ) {
            this->removeAndDestroyBuf ( *pComBuf );
        }
        return tmp;
    }
    return this->multiBufferPopUInt16 ();
}

epicsUInt32 comQueRecv::popUInt32

(

)

Definition at line 211 of file comQueRecv.cpp.

{
    comBuf *pComBuf = this->bufs.first ();
    if ( ! pComBuf ) {
        comBuf::throwInsufficentBytesException ();
    }
    // try first for all in one buffer efficent version
    epicsUInt32 tmp = 0;
    comBuf::popStatus status = pComBuf->pop ( tmp );
    if ( status.success ) {
        this->nBytesPending -= sizeof ( epicsUInt32 );
        if ( status.nowEmpty ) {
            this->removeAndDestroyBuf ( *pComBuf );
        }
        return tmp;
    }
    return this->multiBufferPopUInt32 ();
}

epicsUInt8 comQueRecv::popUInt8

(

)

Definition at line 174 of file comQueRecv.cpp.

{
    comBuf * pComBuf = this->bufs.first ();
    if ( ! pComBuf ) {
        comBuf::throwInsufficentBytesException ();
    }
    epicsUInt8 tmp = '\0';
    comBuf::popStatus status = pComBuf->pop ( tmp );
    if ( ! status.success ) {
        comBuf::throwInsufficentBytesException ();
    }
    if ( status.nowEmpty ) {
        this->removeAndDestroyBuf ( *pComBuf );
    }
    this->nBytesPending--;
    return tmp;
}

void comQueRecv::pushLastComBufReceived

(

comBuf &

bufIn

)

Definition at line 102 of file comQueRecv.cpp.

{
    bufIn.commitIncomming ();
    comBuf * pComBuf = this->bufs.last ();
    if ( pComBuf ) {
        if ( pComBuf->unoccupiedBytes() ) {
            this->nBytesPending += pComBuf->push ( bufIn );
            pComBuf->commitIncomming ();
        }
    }
    unsigned bufBytes = bufIn.occupiedBytes();
    if ( bufBytes ) {
        this->nBytesPending += bufBytes;
        this->bufs.add ( bufIn );
    }
    else {
        bufIn.~comBuf ();
        this->comBufMemMgr.release ( & bufIn );
    }
}

unsigned comQueRecv::removeBytes

(

unsigned

nBytes

)

Definition at line 69 of file comQueRecv.cpp.

{
    unsigned totalBytes = 0u;
    unsigned bytesLeft = nBytes;
    while ( bytesLeft ) {
        comBuf * pComBuf = this->bufs.first ();
        if ( ! pComBuf ) {
            this->nBytesPending -= totalBytes;
            return totalBytes;
        }
        unsigned nBytesThisTime = pComBuf->removeBytes ( bytesLeft );
        if ( pComBuf->occupiedBytes () == 0u ) {
            this->bufs.remove ( *pComBuf );
            pComBuf->~comBuf ();
            this->comBufMemMgr.release ( pComBuf );
        }
        if ( nBytesThisTime == 0u) {
            break;
        }
        totalBytes += nBytesThisTime;
        bytesLeft = nBytes - totalBytes;
    }
    this->nBytesPending -= totalBytes;
    return totalBytes;
}

---

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

• modules/ca/src/client/comQueRecv.h
• modules/ca/src/client/comQueRecv.cpp