pdxx
/
libfastcommon
mirror of https://github.com/happyfish100/libfastcommon.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fast_task_queue.h: add function free_queue_task_arg_offset

master
YuQing 2025-12-23 11:52:42 +08:00
parent 795b328bd6
commit e009d750a5
3 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
HISTORY
View File

@ -1,4 +1,7 @@
Version 1.84 2025-12-23
* fast_task_queue.h: add function free_queue_task_arg_offset
Version 1.83 2025-11-15 Version 1.83 2025-11-15
* fast_task_queue.h: remove field finish_callback * fast_task_queue.h: remove field finish_callback

2
src/fast_task_queue.c
View File

@ -28,7 +28,7 @@
static int task_alloc_init(struct fast_task_info *task, static int task_alloc_init(struct fast_task_info *task,
struct fast_task_queue *queue) struct fast_task_queue *queue)
{ {
task->arg = (char *)task + ALIGNED_TASK_INFO_SIZE + queue->padding_size; task->arg = (char *)task + free_queue_task_arg_offset(queue);
task->send.ptr = &task->send.holder; task->send.ptr = &task->send.holder;
task->send.ptr->size = queue->min_buff_size; task->send.ptr->size = queue->min_buff_size;
if (queue->malloc_whole_block) { if (queue->malloc_whole_block) {

5
src/fast_task_queue.h
View File

@ -236,6 +236,11 @@ static inline int free_queue_alloc_connections(struct fast_task_queue *queue)
return queue->allocator.info.element_total_count; return queue->allocator.info.element_total_count;
} }
static inline int free_queue_task_arg_offset(struct fast_task_queue *queue)
{
return ALIGNED_TASK_INFO_SIZE + queue->padding_size;
}
int free_queue_get_new_buffer_size(const int min_buff_size, int free_queue_get_new_buffer_size(const int min_buff_size,
const int max_buff_size, const int expect_size, int *new_size); const int max_buff_size, const int expect_size, int *new_size);