bufpool.h

Go to the documentation of this file.

#pragma once
 
#include <cx/cx.h>
#include <cx/buffer/buffer.h>
#include <cx/thread/atomic.h>
#include <cx/thread/prqueue.h>
 
 
 
typedef struct BufPool {
    PrQueue freelist;        
    size_t bufsz;            
    uint32 max;              
    atomic(uint32) count;    
} BufPool;
 
void bufpoolInit(_Out_ BufPool* pool, size_t bufsz, uint32 initial, uint32 max);
 
_Must_inspect_result_ _Ret_maybenull_ Buffer bufpoolGet(_Inout_ BufPool* pool);
 
_At_(*buf, _Pre_maybenull_ _Post_null_) void bufpoolPut(_Inout_ BufPool* pool,
                                                        _Inout_ Buffer* buf);
 
uint32 bufpoolInUse(_In_ BufPool* pool);
 
void bufpoolCollect(_Inout_ BufPool* pool);
 
void bufpoolDestroy(_Pre_valid_ _Post_invalid_ BufPool* pool);