ngx_event_move_posted_next

1 定义

ngx_event_move_posted_next 函数 定义在 ./nginx-1.24.0/src/event/ngx_event_posted.c

voidngx_event_move_posted_next(ngx_cycle_t*cycle){ngx_queue_t*q;ngx_event_t*ev;for(q=ngx_queue_head(&ngx_posted_next_events);q!=ngx_queue_sentinel(&ngx_posted_next_events);q=ngx_queue_next(q)){ev=ngx_queue_data(q,ngx_event_t,queue);ngx_log_debug1(NGX_LOG_DEBUG_EVENT,cycle->log,0,"posted next event %p",ev);ev->ready=1;ev->available=-1;}ngx_queue_add(&ngx_posted_events,&ngx_posted_next_events);ngx_queue_init(&ngx_posted_next_events);}

`ngx_event_move_posted_next` 函数的作用是： 将高优先级的“下一次事件”队列中的所有事件标记为就绪， 并批量移入普通延迟处理队列，然后重置高优先级队列为空。 这确保了那些要求更快执行的事件能随普通延迟事件一起被调度，同时强制解锁它们的执行状态。

2 详解

{ngx_queue_t*q;ngx_event_t*ev;for(q=ngx_queue_head(&ngx_posted_next_events);q!=ngx_queue_sentinel(&ngx_posted_next_events);q=ngx_queue_next(q)){ev=ngx_queue_data(q,ngx_event_t,queue);ngx_log_debug1(NGX_LOG_DEBUG_EVENT,cycle->log,0,"posted next event %p",ev);ev->ready=1;ev->available=-1;}ngx_queue_add(&ngx_posted_events,&ngx_posted_next_events);ngx_queue_init(&ngx_posted_next_events);}

#1 局部变量

#2 遍历“下一次”延迟事件队列 ngx_queue_head(&ngx_posted_next_events)： 获取该队列的第一个实际节点（跳过了作为哨兵的头节点）。 ngx_queue_sentinel(&ngx_posted_next_events)： 获取该队列的哨兵节点地址。哨兵节点是循环链表的终点标记，用于判断遍历是否结束。 循环条件 q != ngx_queue_sentinel(...) 表示：只要当前节点不是哨兵，就还有事件未处理。 ngx_queue_next(q)： 每次迭代将 q 后移到链表中的下一个节点。 意义：该循环遍历当前所有存在于 ngx_posted_next_events 队列中的事件，为它们的转移做准备。

#2-1 从节点取回事件对象： Nginx 使用侵入式链表，ngx_event_t 内部有一个名为 queue 的 ngx_queue_t 成员。 ngx_queue_data 宏利用指针运算，通过已知成员 queue 的地址（即 q）和它在结构体中的偏移量， 计算出整个 ngx_event_t 的外层结构体地址，赋给 ev。 意义：拿到真正需要操作的事件对象。

#2-2 调试日志输出

#2-3 设置就绪标志：将事件的 ready 字段赋值为 1

#2-4 available 字段原本用于限制每次事件处理循环中操作的最大次数（如每次最多读/写多少字节）。 置为 -1 表示“无限制”。

#3 队列合并操作： ngx_queue_add 宏将第二个链表（ngx_posted_next_events）的整个节点链插入到 第一个链表（ngx_posted_events）的尾部。 这里 ngx_posted_events 是普通的延迟事件队列， 用于存放待处理的事件（优先级低于 next 队列）。 意义：所有的 next 事件被批量移动到普通队列，它们将在事件处理循环中被统一调度和执行。

#4 重置 next 队列为空： ngx_queue_init 将队列头节点的 prev 和 next 指针都指向自己，形成一个自循环的空队列。 意义：因为已经将所有节点移走，必须重置该队列，以便后续新产生的“下一次”延迟事件能够正常入队。