百分百源码网-让建站变得如此简单! 登录 注册 签到领金币!

主页 | 如何升级VIP | TAG标签

当前位置: 主页>网站教程>网页制作> php-fpm的reload历程
分享文章到:

php-fpm的reload历程

发布时间:09/01 来源:未知 浏览: 关键词:
摘要:reload会让sleep提早完毕,所以就探讨了下fpm的reload操纵怎样实现?

php-fpm的reload历程

本文在PHP7.0 fpm下剖析,process_control_timeout设定不为0。

重新启动信号

第一,我们从 可以知道,fpm的reload操纵实际上就是对fpm进程发送了USR2信号。

fpm的master进程中, 通过 注册了信号处置函数 :

int fpm_signals_init_main() /* {{{ */{ struct sigactionact;
  // 。。。。。。  memset(&act, 0, sizeof(act));
act.sa_handler = sig_handler;
sigfillset(&act.sa_mask);
  if (0 > sigaction(SIGTERM,  &act, 0) ||
    0 > sigaction(SIGINT,  &act, 0) ||
    0 > sigaction(SIGUSR1,  &act, 0) ||
    0 > sigaction(SIGUSR2,  &act, 0) ||
    0 > sigaction(SIGCHLD,  &act, 0) ||
    0 > sigaction(SIGQUIT,  &act, 0)) {
zlog(ZLOG_SYSERROR, "failed to init signals: sigaction()"); return -1;
} return 0;
}/* }}} */

简而言之,通过 设定为block掉所有的信号,然后通过sigaction设定对应的信号处置函数。

当我们reload fpm时,systemctl向fpm的master进程发送USR2信号,施行函数 :

static void sig_handler(int signo) /* {{{ */{ static const char sig_chars[NSIG + 1] = {
[SIGTERM] = 'T',
[SIGINT]  = 'I',
[SIGUSR1] = '1',
[SIGUSR2] = '2',
[SIGQUIT] = 'Q',
[SIGCHLD] = 'C'
}; char s;
        // ***
s = sig_chars[signo];
zend_quiet_write(sp[1], &s, sizeof(s));
errno = saved_errno;
}/* }}} */

关键点在 zend_quiet_write,它就是 。sig_handler函数就是向sp[ 1 ]中写入了一个字符串2。

此处需要留意的是,sp[0]和sp[1]是通过 创立的当地套接字。

master开端重新启动 此前的信号处置函数,在信号发生的时候会被调取,但是程序的主逻辑依然不会被打乱,那fpm master进程如何知道要reload呢?

答案就在 中,这是master进程的事件轮回。

在轮回此前, 我们需要用 sp[0] 一个 struct fpm_event_s,增加到监听的fd中:

int fpm_event_set(struct fpm_event_s *ev, int fd, int flags, void (*callback)(struct fpm_event_s *, short, void *), void *arg) /* {{{ */{ if (!ev || !callback || fd < -1) { return -1;
}
memset(ev, 0, sizeof(struct fpm_event_s));
ev->fd = fd;
ev->callback = callback;
ev->arg = arg;
ev->flags = flags; return 0;
}/* }}} */

然后将这个 struct fpm_event_s,也就是代码中的ev, 监听的fd中。

实际上,这个增加历程也和fpm不一样的异步模型有关(都是由对应fpm_event_module_s的add办法实现的),比方 就是将ev参数团体放到epoll_event的data.ptr中的。(poll的add可以参照 )

当所有的fd都增加了之后(当然不仅仅是signal相关的fd咯),我们就可以使用 等候事件降临了。 (epoll和poll也都各自实现了wait办法)

好,回到sig_handler给sp[1]写了个字符串2。 wait办法 接到了信号,拿到对应的ev,调取 ,实际上就是调取了 ,就是 :

static void fpm_got_signal(struct fpm_event_s *ev, short which, void *arg) /* {{{ */{ char c; int res, ret; int fd = ev->fd;
  do {
res = read(fd, &c, 1);
  switch (c) { // 。。。。。。
case '2' :                  /* SIGUSR2 */
zlog(ZLOG_DEBUG, "received SIGUSR2");
zlog(ZLOG_NOTICE, "Reloading in progress ...");
fpm_pctl(FPM_PCTL_STATE_RELOADING, FPM_PCTL_ACTION_SET); break;
}
  if (fpm_globals.is_child) { break;
}
} while (1); return;
}/* }}} */

假如接收到了字符串2,则施行

fpm_pctl(FPM_PCTL_STATE_RELOADING, FPM_PCTL_ACTION_SET)

实际上就 :

void fpm_pctl(int new_state, int action) /* {{{ */{ switch (action) { case FPM_PCTL_ACTION_SET :
//。。。。。。
fpm_signal_sent = 0;
fpm_state = new_state;
zlog(ZLOG_DEBUG, "switching to '%s' state", fpm_state_names[fpm_state]); /* fall down */  case FPM_PCTL_ACTION_TIMEOUT :
fpm_pctl_action_next(); break; //。。。。。
}
}/* }}} */

即,将fpm_state设定为FPM_PCTL_STATE_RELOADING后,没有break,连续施行 :

static void fpm_pctl_action_next() /* {{{ */
{ int sig, timeout;
  if (!fpm_globals.running_children) {
fpm_pctl_action_last();
}
  if (fpm_signal_sent == 0) { if (fpm_state == FPM_PCTL_STATE_TERMINATING) { sig = SIGTERM;
} else { sig = SIGQUIT;
}
timeout = fpm_global_config.process_control_timeout;
} else { if (fpm_signal_sent == SIGQUIT) { sig = SIGTERM;
} else { sig = SIGKILL;
}
timeout = 1;
}
fpm_pctl_kill_all(sig);
fpm_signal_sent = sig;
fpm_pctl_timeout_set(timeout);
}
/* }}} */

即,给所有子进程发送SIGQUIT信号。

这边还有一个 ,这个等会计议。

子进程处置信号 父进程发送完信号了,就该子进程处置啦。

子进程只要 交给sig_soft_quit处置。子进程初始化完成后,收到了SIGQUIT信号,由sig_soft_quit处置,终究调取 处置:

void fcgi_terminate(void){
in_shutdown = 1;
}

就是将in_shutdown设定为1。

子进程退出 子进程的轮回主体在 fcgi_accept_request 中,其中多出推断in_shutdown,若为1则直接退出:

超时处置 前面提到的 是 。施行了如下操纵:

fpm_pctl(FPM_PCTL_STATE_UNSPECIFIED, FPM_PCTL_ACTION_TIMEOUT);

在这种前提下, ,直接退出了子进程。

为什么sleep会被打断? 我们可以看到, 就是系统调取sleep(php_sleep是sleep的一个宏):

/* {{{ proto void sleep(int seconds)
   Delay for a given number of seconds */PHP_FUNCTION(sleep)
{
zend_longnum;
  if (zend_parse_parameters(ZEND_NUM_ARGS(), "l", &num) == FAILURE) {
RETURN_FALSE;
}
php_sleep((unsigned int)num);
}/* }}} */

sleep函数施行时,此时进程的状态是S:

interruptiblesleep 此时一旦有信号触发,立马处置信号,比方我们刚刚说过的SIGQUIT,完毕了之后发明,sleep施行完了。

由于 写了啊:

<b>sleep</b>() makesthecallingthreadsleepuntil <i>seconds</i> secondshave 
elapsedor a signalarriveswhichis not ignored.

需要留意的是, ,所以即便信号打断了sleep,也仅仅是跳过sleep连续施行罢了。

以上就是php-fpm的reload历程的具体内容,更多请关注百分百源码网其它相关文章!

打赏

打赏

取消

感谢您的支持,我会继续努力的!

扫码支持
扫码打赏,你说多少就多少

打开支付宝扫一扫,即可进行扫码打赏哦

百分百源码网 建议打赏1~10元,土豪随意,感谢您的阅读!

共有151人阅读,期待你的评论!发表评论
昵称: 网址: 验证码: 点击我更换图片
最新评论

本文标签

广告赞助

能出一分力是一分吧!

订阅获得更多模板

本文标签

广告赞助

订阅获得更多模板