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過程的詳細內容,更多請關注TW511.COM其它相關文章!