Lines Matching refs:item
101 TSkBuffer* item = NULL; in sk_buffer_mng_destroy() local
103 TAILQ_FOREACH_SAFE(item, &mng->free_list, entry, tmp) in sk_buffer_mng_destroy()
105 TAILQ_REMOVE(&mng->free_list, item, entry); in sk_buffer_mng_destroy()
106 delete_sk_buffer(item); in sk_buffer_mng_destroy()
117 TSkBuffer* item = TAILQ_FIRST(&mng->free_list); in alloc_sk_buffer() local
118 if (item != NULL) in alloc_sk_buffer()
120 TAILQ_REMOVE(&mng->free_list, item, entry); in alloc_sk_buffer()
122 return item; in alloc_sk_buffer()
125 item = new_sk_buffer(mng->size); in alloc_sk_buffer()
126 if (NULL == item) in alloc_sk_buffer()
131 return item; in alloc_sk_buffer()
150 TSkBuffer* item = NULL; in recycle_sk_buffer() local
152 TAILQ_FOREACH_SAFE(item, &mng->free_list, entry, tmp) in recycle_sk_buffer()
154 if ((now - item->last_time) < mng->expired) in recycle_sk_buffer()
159 TAILQ_REMOVE(&mng->free_list, item, entry); in recycle_sk_buffer()
160 delete_sk_buffer(item); in recycle_sk_buffer()
179 TSkBuffer* item = NULL; in rw_cache_destroy() local
181 TAILQ_FOREACH_SAFE(item, &cache->list, entry, tmp) in rw_cache_destroy()
183 TAILQ_REMOVE(&cache->list, item, entry); in rw_cache_destroy()
184 free_sk_buffer(cache->pool, item); in rw_cache_destroy()
199 TSkBuffer* item = NULL; in cache_copy_out() local
201 TAILQ_FOREACH_SAFE(item, &cache->list, entry, tmp) in cache_copy_out()
203 skip_len = (item->data_len > left) ? left : item->data_len; in cache_copy_out()
206 memcpy(out_buff, item->data, skip_len); in cache_copy_out()
211 item->data_len -= skip_len; in cache_copy_out()
212 item->data += skip_len; in cache_copy_out()
213 if (item->data_len > 0) in cache_copy_out()
221 TAILQ_REMOVE(&cache->list, item, entry); in cache_copy_out()
222 free_sk_buffer(cache->pool, item); in cache_copy_out()
319 TSkBuffer* item = alloc_sk_buffer(cache->pool); in cache_append_data() local
320 if (item == NULL) in cache_append_data()
325 cache_append_buffer(&keep_list, item); in cache_append_data()
327 if (left <= item->size) in cache_append_data()
329 memcpy(item->head, (char*)data + len - left, left); in cache_append_data()
330 item->data_len = left; in cache_append_data()
334 memcpy(item->head, (char*)data + len - left, item->size); in cache_append_data()
335 item->data_len = item->size; in cache_append_data()
336 left -= item->size; in cache_append_data()
362 TSkBuffer* item = alloc_sk_buffer(cache->pool); in cache_udp_recv() local
363 if (NULL == item) in cache_udp_recv()
370 …int32_t rc = ff_hook_recvfrom(fd, item->data, item->size, 0, (struct sockaddr*)remote_addr, &addr_… in cache_udp_recv()
373 free_sk_buffer(cache->pool, item); in cache_udp_recv()
386 item->data_len += rc; in cache_udp_recv()
387 cache_append_buffer(cache, item); in cache_udp_recv()
404 TSkBuffer* item = TAILQ_LAST(&cache->list, __sk_buff_list); in cache_tcp_recv() local
405 if ((NULL == item) in cache_tcp_recv()
406 || ((item->data_len + item->data) >= item->end)) in cache_tcp_recv()
408 item = alloc_sk_buffer(cache->pool); in cache_tcp_recv()
409 if (item == NULL) in cache_tcp_recv()
413 cache_append_buffer(cache, item); in cache_tcp_recv()
416 uint8_t* buff = item->data + item->data_len; in cache_tcp_recv()
417 uint32_t remain = item->end - item->data - item->data_len; in cache_tcp_recv()
439 item->data_len += recvd_len; in cache_tcp_recv()
465 TSkBuffer* item = NULL; in cache_tcp_send() local
467 TAILQ_FOREACH_SAFE(item, &cache->list, entry, tmp) in cache_tcp_send()
470 ret = ff_hook_send(fd, item->data, item->data_len, 0); in cache_tcp_send()
477 if (ret < (int32_t)item->data_len) in cache_tcp_send()
572 TSkBuffer* item = (TSkBuffer*)block; in get_next_block() local
573 if ((NULL == cache) || (NULL == item)) in get_next_block()
578 return (TBuffBlockPtr)TAILQ_NEXT(item, entry); in get_next_block()
584 TSkBuffer* item = (TSkBuffer*)block; in get_block_data() local
592 *(uint8_t**)data = item->data; in get_block_data()
597 *len = (int32_t)item->data_len; in get_block_data()
610 TSkBuffer* item = NULL; in read_cache_data() local
612 TAILQ_FOREACH_SAFE(item, &cache->list, entry, tmp) in read_cache_data()
615 if (left_len <= item->data_len) in read_cache_data()
621 copy_len = item->data_len; in read_cache_data()
626 memcpy((char*)data + offset, item->data, copy_len); in read_cache_data()
654 TSkBuffer* item = NULL; in read_cache_begin() local
655 TAILQ_FOREACH(item, &cache->list, entry) in read_cache_begin()
657 uint8_t* start_ptr = item->data; in read_cache_begin()
658 uint32_t real_left = item->data_len; in read_cache_begin()