Lines Matching refs:sbm
23 SBGetCurnum(sb_manager_t sbm) in SBGetCurnum() argument
25 return sbm->cur_num; in SBGetCurnum()
31 sb_manager_t sbm = (sb_manager_t)calloc(1, sizeof(sb_manager)); in SBManagerCreate() local
32 if (!sbm) { in SBManagerCreate()
37 sbm->chunk_size = chunk_size; in SBManagerCreate()
38 sbm->cnum = concurrency; in SBManagerCreate()
39 sbm->mp = (mem_pool_t)MPCreate(chunk_size, in SBManagerCreate()
42 if (!sbm->mp) { in SBManagerCreate()
44 free(sbm); in SBManagerCreate()
48 sbm->freeq = CreateSBQueue(concurrency); in SBManagerCreate()
49 if (!sbm->freeq) { in SBManagerCreate()
51 MPDestroy(sbm->mp); in SBManagerCreate()
52 free(sbm); in SBManagerCreate()
56 return sbm; in SBManagerCreate()
60 SBInit(sb_manager_t sbm, uint32_t init_seq) in SBInit() argument
65 buf = SBDequeue(sbm->freeq); in SBInit()
72 buf->data = MPAllocateChunk(sbm->mp); in SBInit()
78 sbm->cur_num++; in SBInit()
85 buf->size = sbm->chunk_size; in SBInit()
93 SBFree(sb_manager_t sbm, struct tcp_send_buffer *buf) in SBFree() argument
98 SBEnqueue(sbm->freeq, buf); in SBFree()
102 SBPut(sb_manager_t sbm, struct tcp_send_buffer *buf, const void *data, size_t len) in SBPut() argument
134 SBRemove(sb_manager_t sbm, struct tcp_send_buffer *buf, size_t len) in SBRemove() argument