diff --git a/src/ca/comQueSend.cpp b/src/ca/comQueSend.cpp index 3e5bad307..54252b66c 100644 --- a/src/ca/comQueSend.cpp +++ b/src/ca/comQueSend.cpp @@ -63,33 +63,6 @@ tsFreeList < class comBuf, 0x20 > comBuf::freeList; -inline bufferReservoir::~bufferReservoir () -{ - this->drain (); -} - -inline comBuf *bufferReservoir::fetchOneBuffer () -{ - return this->reservedBufs.get (); -} - -inline bool bufferReservoir::addOneBuffer () -{ - comBuf *pBuf = new comBuf; - if ( pBuf ) { - this->reservedBufs.add ( *pBuf ); - return true; - } - else { - return false; - } -} - -inline unsigned bufferReservoir::nBytes () -{ - return ( this->reservedBufs.count () * comBuf::maxBytes () ); -} - comQueSend::comQueSend ( wireSendAdapter & wireIn ) : wire ( wireIn ), nBytesPending ( 0u ) { diff --git a/src/ca/comQueSend_IL.h b/src/ca/comQueSend_IL.h index 202fda5fa..045a94fe5 100644 --- a/src/ca/comQueSend_IL.h +++ b/src/ca/comQueSend_IL.h @@ -18,6 +18,33 @@ #ifndef comQueSend_ILh #define comQueSend_ILh +inline bufferReservoir::~bufferReservoir () +{ + this->drain (); +} + +inline comBuf *bufferReservoir::fetchOneBuffer () +{ + return this->reservedBufs.get (); +} + +inline bool bufferReservoir::addOneBuffer () +{ + comBuf *pBuf = new comBuf; + if ( pBuf ) { + this->reservedBufs.add ( *pBuf ); + return true; + } + else { + return false; + } +} + +inline unsigned bufferReservoir::nBytes () +{ + return ( this->reservedBufs.count () * comBuf::maxBytes () ); +} + inline void bufferReservoir::drain () { comBuf *pBuf;