|
| cQueueBytes (size_t nGrowSizeChunk=8 *1024, size_t nGrowSizeMax=cHeap::k_ALLOC_MAX) noexcept |
|
| ~cQueueBytes () |
|
bool | InsertDataHead (const BYTE *pDataSrc, size_t iLen) |
|
bool | SetAllData (const BYTE *pData, size_t iLen) |
|
| cQueueDyn (ITERATE_t nGrowSizeChunk=128, ITERATE_t nGrowSizeMax=(cHeap::k_ALLOC_MAX/sizeof(BYTE))) noexcept |
|
| ~cQueueDyn () |
|
void | put_GrowSizeChunk (ITERATE_t nGrowSizeChunk) noexcept |
|
ITERATE_t | get_GrowSizeChunk () const noexcept |
|
bool | MakeWritePrepared (ITERATE_t iDesiredCount=1) |
|
BYTE * | GetWritePrepared (ITERATE_t iDesiredCount=1) |
|
bool | WriteQ (BYTE val) |
|
void | WriteQ (cQueueRead< BYTE > &queue) |
|
HRESULT | WriteQty (const BYTE *pVal, ITERATE_t iCount) |
|
HRESULT | WriteX (const void *pData, size_t nDataSize) |
|
| cQueueRW () noexcept |
|
| cQueueRW (TYPE *pData, ITERATE_t iDataAlloc, ITERATE_t iReadLast, ITERATE_t iWriteLast, ITERATE_t iAutoReadCommit=0) |
|
| cQueueRW (const TYPE *pData, ITERATE_t iDataMax) |
|
| ~cQueueRW () |
|
void | ReadCommitCheck () |
|
ITERATE_t | get_AutoReadCommit () const |
|
void | put_AutoReadCommit (ITERATE_t iAutoReadCommit=8 *1024) |
|
void | put_ReadIndex (ITERATE_t iReadLo) |
|
STREAM_SEEKRET_t | SeekQ (STREAM_OFFSET_t iOffset, SEEK_ORIGIN_TYPE eSeekOrigin=SEEK_Set) |
|
HRESULT | ReadQty (TYPE *pData, ITERATE_t iDataMaxQty) |
|
HRESULT | ReadX (void *pData, size_t nDataSize) |
|
bool | isFullQ () const |
|
ITERATE_t | get_WriteQty () const |
|
TYPE * | get_WritePtr () const |
|
HRESULT | WriteQty (const TYPE *pData, ITERATE_t iQtyMax) |
|
HRESULT | WriteX (const void *pData, size_t nDataSize) |
|
void | AdvanceWrite (ITERATE_t iCount=1) |
|
| cQueueRead (const BYTE *pData=nullptr, ITERATE_t iReadLast=0, ITERATE_t iWriteLast=0) noexcept |
|
| ~cQueueRead () |
|
const BYTE * | get_ReadPtr () const |
|
void | SetQueueRead (const BYTE *pData, ITERATE_t iReadLast=0, ITERATE_t iWriteLast=0) |
|
BYTE | Read1 (void) |
|
HRESULT | ReadPeek (BYTE *pData, ITERATE_t iDataMaxQty) |
|
HRESULT | ReadQty (BYTE *pData, ITERATE_t iDataMaxQty) |
|
void | ReadCommitNow () |
|
| cQueueBase (ITERATE_t iReadLast=0, ITERATE_t iWriteLast=0) noexcept |
|
void | InitQ (ITERATE_t iReadLast=0, ITERATE_t iWriteLast=0) noexcept |
|
bool | isEmptyQ () const noexcept |
|
void | EmptyQ () noexcept |
|
ITERATE_t | get_ReadIndex () const noexcept |
|
ITERATE_t | get_WriteIndex () const noexcept |
|
ITERATE_t | get_ReadQty () const |
|
void | AdvanceRead (ITERATE_t iCount=1) |
|
STREAM_SEEKRET_t | SeekQ (STREAM_OFFSET_t iOffset, SEEK_ORIGIN_TYPE eSeekOrigin=SEEK_Set) |
|
a queue that grows the memory allocation as needed. free on destruct.