bufchain.h

Go to the documentation of this file.

#pragma once
 
#include <cx/cx.h>
#include "cx/buffer/buffer.h"
#include "cx/utils/compare.h"
 
CX_C_BEGIN
 
 
 
typedef struct BufChainNode BufChainNode;
typedef struct BufChainNode {
    BufChainNode* next;   
    Buffer buf;           
} BufChainNode;
 
typedef struct BufChain {
    BufChainNode* head;   
    BufChainNode* tail;   
    uintptr cursor;       
    size_t total;         
    size_t segsz;         
} BufChain;
 
typedef bool (*bufchainZCCB)(_Inout_ Buffer buf, size_t off, _Pre_opt_valid_ void* ctx);
 
void bufchainInit(_Out_ BufChain* chain, size_t segsz);
 
size_t bufchainRead(_Inout_ BufChain* chain, _Out_writes_bytes_(bytes) uint8* buf, size_t bytes);
 
_meta_inline size_t bufchainReadBuf(_Inout_ BufChain* chain, _Inout_ Buffer buf, size_t maxbytes)
{
    buf->len = bufchainRead(chain, buf->data, min(buf->sz, maxbytes));
    return buf->len;
}
 
size_t bufchainPeek(_Inout_ BufChain* chain, _Out_writes_bytes_(bytes) uint8* buf, size_t off,
                    size_t bytes);
 
_meta_inline size_t bufchainPeekBuf(_Inout_ BufChain* chain, _Inout_ Buffer buf, size_t off,
                                    size_t maxbytes)
{
    buf->len = bufchainPeek(chain, buf->data, off, min(buf->sz, maxbytes));
    return buf->len;
}
 
size_t bufchainSkip(_Inout_ BufChain* chain, size_t bytes);
 
size_t bufchainReadZC(_Inout_ BufChain* chain, size_t maxbytes, bufchainZCCB cb,
                      _Inout_opt_ void* ctx);
 
size_t bufchainGatherIov(_In_ BufChain* chain, _Out_writes_to_(maxiov, *count) BufIov* iov,
                         size_t maxiov, _Out_opt_ size_t* count);
 
void bufchainWrite(_Inout_ BufChain* chain, _In_reads_bytes_(bytes) const uint8* buf, size_t bytes);
 
_meta_inline void bufchainWriteBuf(_Inout_ BufChain* chain, _In_ Buffer buf)
{
    bufchainWrite(chain, buf->data, buf->len);
}
 
_At_(*buf, _Pre_notnull_ _Post_null_) void bufchainWriteZC(BufChain* chain, _Inout_ Buffer* buf);
 
void bufchainDestroy(_Pre_notnull_ _Post_invalid_ BufChain* chain);
 
 
CX_C_END