ngx_unlock_mutexes

1 定义

ngx_unlock_mutexes 函数 定义在 ./nginx-1.24.0/src/os/unix/ngx_process.c

staticvoidngx_unlock_mutexes(ngx_pid_tpid){ngx_uint_ti;ngx_shm_zone_t*shm_zone;ngx_list_part_t*part;ngx_slab_pool_t*sp;/* * unlock the accept mutex if the abnormally exited process * held it */if(ngx_accept_mutex_ptr){(void)ngx_shmtx_force_unlock(&ngx_accept_mutex,pid);}/* * unlock shared memory mutexes if held by the abnormally exited * process */part=(ngx_list_part_t*)&ngx_cycle->shared_memory.part;shm_zone=part->elts;for(i=0;/* void */;i++){if(i>=part->nelts){if(part->next==NULL){break;}part=part->next;shm_zone=part->elts;i=0;}sp=(ngx_slab_pool_t*)shm_zone[i].shm.addr;if(ngx_shmtx_force_unlock(&sp->mutex,pid)){ngx_log_error(NGX_LOG_ALERT,ngx_cycle->log,0,"shared memory zone \"%V\" was locked by %P",&shm_zone[i].shm.name,pid);}}}

ngx_unlock_mutexes 函数 用于在 Nginx master 进程监测到某个 worker 进程异常退出后， 强制释放该进程可能持有的共享内存互斥锁，防止死锁。

2 详解

1 函数签名

staticvoidngx_unlock_mutexes(ngx_pid_tpid)

无返回值 参数 ngx_pid_t pid 异常退出的进程 ID

2 逻辑流程

1 局部变量 2 处理 Accept 互斥锁 3 遍历共享内存

1 局部变量

{ngx_uint_ti;ngx_shm_zone_t*shm_zone;ngx_list_part_t*part;ngx_slab_pool_t*sp;

2 处理 Accept 互斥锁

/* * unlock the accept mutex if the abnormally exited process * held it */if(ngx_accept_mutex_ptr){(void)ngx_shmtx_force_unlock(&ngx_accept_mutex,pid);}

若异常退出进程持有 accept_mutex，则将其解锁 ngx_accept_mutex_ptr 是 accept 锁在共享内存中的地址指针 仅在启用了 accept mutex 时才非空。 ngx_shmtx_force_unlock：强制解锁函数

3 遍历共享内存

/* * unlock shared memory mutexes if held by the abnormally exited * process */part=(ngx_list_part_t*)&ngx_cycle->shared_memory.part;shm_zone=part->elts;

初始化要遍历的 ngx_cycle->shared_memory 链表 ngx_cycle->shared_memory 是 ngx_list_t 类型， 其第一个链表节点直接内嵌在 part 成员中。 part 指向该首个节点。 shm_zone 指向该节点内的元素数组（elts）， 元素类型为 ngx_shm_zone_t。

for(i=0;/* void */;i++){if(i>=part->nelts){if(part->next==NULL){break;}part=part->next;shm_zone=part->elts;i=0;}sp=(ngx_slab_pool_t*)shm_zone[i].shm.addr;if(ngx_shmtx_force_unlock(&sp->mutex,pid)){ngx_log_error(NGX_LOG_ALERT,ngx_cycle->log,0,"shared memory zone \"%V\" was locked by %P",&shm_zone[i].shm.name,pid);}}}

#1 无限循环，通过内部条件判断退出。 i 作为当前节点内元素数组的索引。

#2 当索引 i 达到当前节点内元素数量 part->nelts 时： 检查是否有下一个节点 part->next，若 无则链表遍历结束，break 退出循环。 若存在下一个节点，将 part 移动到下一节点， shm_zone 重新指向新节点的元素数组，并将 i 重置为 0。

#3 获取当前共享内存区域的实际起始地址， 并强制转换为 ngx_slab_pool_t *。 shm_zone[i].shm.addr 在共享内存初始化时被设置为 slab pool 的基地址。

#4 对 slab pool 内部的 mutex 调用 ngx_shmtx_force_unlock。 返回值非零表示锁确实被该 pid 持有并已成功强制解锁。 若解锁成功，记录一条 ALERT 级别日志