pool.h

Go to the documentation of this file.

 
 
#pragma once
// This header file is auto-generated!
// Do not make changes to this file or they will be overwritten.
// clang-format off
#include <cx/obj.h>
#include <cx/struct.h>
#include <cx/net/net_shared.h>
#include <cx/buffer/bufpool.h>
 
CX_C_BEGIN
 
typedef struct NetPool NetPool;
typedef struct NetPool_WeakRef NetPool_WeakRef;
saDeclarePtr(NetPool);
saDeclarePtr(NetPool_WeakRef);
#define _sti_NetPool _sti_object
#define SType_NetPool NetPool*
#define STStorageType_NetPool NetPool*
#define STypeArg_NetPool(type, val) stgeneric(object, (ObjInst*)objInstCheckClass(NetPool, val))
#define STypeArgPtr_NetPool(type, val) (stgeneric*)objInstCheckClassPtr(NetPool, val)
#define STypeCheckedArg_NetPool(type, val)    stType(type), stArg(type, val)
#define STypeCheckedPtrArg_NetPool(type, val) stType(type), stArgPtr(type, val)
 
 
 
typedef struct NetPool {
    union {
        ObjIface* _;
        void* _is_NetPool;
        void* _is_ObjInst;
    };
    ObjClassInfo* _clsinfo;
    atomic(uintptr) _ref;
    atomic(ptr) _weakref;
 
    BufPool msgbuf;
    PrQueue msghdr;        
} NetPool;
extern ObjClassInfo NetPool_clsinfo;
#define NetPool(inst) objInstCheckClass(NetPool, inst)
#define NetPoolNone ((NetPool*)NULL)
 
typedef struct NetPool_WeakRef {
    union {
        ObjInst* _inst;
        void* _is_NetPool_WeakRef;
        void* _is_ObjInst_WeakRef;
    };
    atomic(uintptr) _ref;
    RWLock _lock;
} NetPool_WeakRef;
#define NetPool_WeakRef(inst) objWeakRefCheckClass(NetPool, inst)
 
_objfactory_guaranteed NetPool* NetPool_create(_In_ const NetQueueConfig* conf);
#define netpoolCreate(conf) NetPool_create(conf)
 
NetMessage* NetPool_allocHeader(_In_ NetPool* self);
#define netpoolAllocHeader(self) NetPool_allocHeader(NetPool(self))
 
_Check_return_ _Ret_maybenull_ NetMessage* NetPool_allocMsg(_In_ NetPool* self);
#define netpoolAllocMsg(self) NetPool_allocMsg(NetPool(self))
 
_At_(*msg, _Pre_notnull_ _Post_null_) void NetPool_freeMsg(_In_ NetPool* self, _Inout_ NetMessage** msg);
#define netpoolFreeMsg(self, msg) NetPool_freeMsg(NetPool(self), msg)
 
void NetPool_freeMsgQueue(_In_ NetPool* self, _Inout_ NetMsgQueue* mq);
#define netpoolFreeMsgQueue(self, mq) NetPool_freeMsgQueue(NetPool(self), mq)
 
 
CX_C_END