nginx ソースコード学習メモ (21) - イベント モジュール 2 - イベント駆動型コア ngx_process_events_and_timers

まず最初に、前のサブスレッド実行操作には関与しないコンテンツ ngx_process_events_and_timers があることを思い出してください。今日はこの関数を学習します。

この記事の引用元: http://blog.csdn.net/lengzijian/article/details/7601730

セクション 19 のスクリーンショットをいくつか見てみましょう:

今日はイベント駆動関数、図の赤い部分を中心に説明します:

[cpp]ビュー 普通のコピープリント？

1. src/event/ngx_event.c
3. void
4. ngx_process_events_and_timers(ngx _cycle_t *サイクル)
5. {
6. ngx_uint_t フラグ
7. ngx_msec_t タイマー、デルタ;
9. (ngx_timer_resolution) { 時間 r = NGX_TIMER_INFINITE ;
10. } 他の
{
12. タイマー = ngx_event_find_timer();
13. フラグ = NGX_UPDATE_TIME } /*
ngx_use_accept_mutex 変数は、ミューテックス
15. を使用するかどうかを表します
16. はデフォルトで使用され、accept_mutex off コマンドを使用してオフにできます。
17. ngx_accept_disabled 変数は ng で計算されます。 x_event_accept 関数。
18. ngx_accept_disabled が 0 より大きい場合、プロセスが受け入れるリンクが多すぎることを意味します。
19. したがって、受け入れミューテックスを獲得するために競合する機会を放棄し、自分自身を 1 つ減らします。
20. 次に、既存の接続でイベントの処理を続けます。
21. nginx はこれを利用して、継承された接続の基本的な負荷分散を実装します。
22. ngx_accept_disabled-- ;
23. /* ミューテックスのロックを正常に取得した場合にのみ、Listen は EPOLL にワードを入れることができます。
25. したがって、これにより、1 つのプロセスだけが listen ソケットを持つことが保証されるため、すべてのプロセスが epoll_wait でブロックされた場合でも、
26. はグループパニックを引き起こしません。
27. プロセスがロックを取得すると、NGX_POST_EVENTS フラグが追加されます。
28. このフラグの機能は、生成されたすべてのイベントを キュー に入れ、イベントが解放された後にゆっくりと処理することです。 - - 処理される、処理されるなど。効率は低い。 ️
29. } else{
未取得 結果のプロセスには、当然のことながら、NGX_POST_EVENTS フラグは必要ありません。
32. ただし、ロックを争う前に遅延時間を設定する必要があります。
33. */
34. (タイマー == ngx_timer_infinite
35. || タイマー & gt; ex_dlay) {
36. タイマー = ngx_acceth_mutex_lay
38. delta = ngx_current_msec;
/*次に、epoll は待機イベントを開始します
42. ngx_process_events の具体的な実装epoll モジュールの ngx_epoll_process_events 関数に対応します
ここで詳しく説明します
45. */
46. ( void
) ngx_process_events(cycle, timer, flags);
47. / / 統計この待機イベントの消費時間
48. delta = ngx_current_msec-delta
49. ngx_log_debug1(NGX_LOG_DEBUG_EVENT,cycle->log, 0,
50. /*
ngx_posted_accept_events はイベント
52. queue であり、リッスンソケットからの受け入れイベント epoll 待機を一時的に保存します。
上記の NGX_POST_EVENTS フラグが使用された後、すべての受け入れイベントはこの
54. キューに一時的に保存されます
*/
56. if
(ngx_posted_accept_events ) {
57. ngx_event_process_posted(cycle, &ngx_posted_accept_events);
58. } //すべての受け入れイベントが処理された後、ロックが保持されている場合は解放します。
59. if (ngx_accept_mutex_held) {
60. ngx_shmtx_unlock(&ngx_accept_mutex) }
62. /*
63. デルタは前です統計的に時間がかかる場合は、ミリ秒レベルの時間がかかる場合は、すべての時刻のタイマーを確認します。
64. タイムアウトの場合は、時間切れのタイマーを時間 rbtree から削除し、そのハンドラー関数を呼び出します。処理する対応するイベント
65. */
66. if
(delta) {
67. ngx_event_expire_timers();
}
ngx_log_debug1 (NGX_LOG_DEBUG_EVENT、サイクル>ログ、0、
71. /*
72. 通常のイベントの処理 (接続イベントで取得されたデータの読み取りおよび書き込み)、
73. 各イベントには独自のハンドラー メソッド、
74. */
75. if
76. (ngx_posted_events) {
77. if (ngx_threaded) {
ngx_wakeup_worker_thread(cycle); :
78. } }
79. 受け入れイベントについては以前お話しましたが、実際には、ソケット上に新しいイベントがあるかどうかを監視します。受け入れ時のハンドラーメソッド:
ngx_event_accept:
81. [cpp] view 普通のコピープリント？
    1. src/event/ngx_event_accept.c
    3. void
    4. ngx_event_accept(ngx_even t_t *ev)
    5. {
    6. socklen_t socklen;  
    7. ngx_err_t エラー;  
    8. ngx_log_t *ログ;  
    9. ngx_socket_t s;  
    10. ngx_event_t *rev、*wev;  
    11. ngx_listening_t *ls;  
    12. ngx_connection_t *c, *lc;  
    13. ngx_event_conf_t *ecf;  
    14. u_char sa[NGX_SOCKADDRLEN];  
    16. //一部省略
    18. lc = ev->data;  
    19. ls = lc->リスニング;  
    20. ev->ready = 0;  
    22. ngx_log_debug2(NGX_LOG_DEBUG_EVENT, ev->log, 0,
    23. "%V で受け入れます、準備完了: %d", &ls->addr_text, ev->利用可能);  
    25. do {
    26. socklen = NGX_SOCKADDRLEN;  
    27. //新しい接続を受け入れます
    28. s = accept(lc->fd, (struct sockaddr *)さ、&socklen);  
    29. //一部省略
    31. /*
    32. 新しい接続を受け入れた後、新たに計算ngx_accept_disabledの值、
    34. ここでは、私たちは他の内容を閲覧できます。只今
    35. 「总接続数的」 8分の1 - 残りの接続数「
    36. すべての接続は、各プロセスで設定された最大接続数を指し、この数字はファイル内で再構成できます。合計接続数の 7/8 を超えると、NGX_ACCEPT_DISABLED が 0 より大きくなり、接続が過負荷になります
    38. */
    40. ngx_accept_disabled = ngx_cycle->connection_n / 8
    - ngx_cycle->free_connection_n
    c = ngx_get_connection(s, ev- >ログ);
    44. //接続が閉じられた場合にのみ解放 pool
    46. if (c->pool == NULL ) {
    ngx _close_accepted_connection(c);
    48. ）; ;
    if (log == null) {
    49. ngx_close_accepted_connection (c);  
    51. /* aio にはブロッキング モードを設定し、その他にはノンブロッキング モードを設定します*/
    53. if (ngx_inherited_nonblocking) {
    54. if (ngx_event_flags & NGX_USE_AIO_EVENT) {
    55. if (ngx_blocking(s) == -1) {
    56. ngx_log_error(NGX_LOG_ALERT, ev->log, ngx_socket_errno,
    57. ngx_blocking_n " 失敗しました");  
    58. ngx_close_accepted_connection(c);  
    59. 戻る;  
    60. }
    61. }
    63. } else {
    64. //我们epollモデルを使用、这里我们设置连接はノンブロッキングです
    65. if (!(ngx_event_flags & (NGX_USE_AIO_EVENT|NGX_USE_RTSIG_EVENT))) {
    66. if (ngx_nonblocking(s) == -1) {
    67. ngx_log_error(NGX_LOG_ALERT, ev-> ;log、ngx_socket_errno、
    68. ngx_nonblocking_n " 失敗しました");  
    69. ngx_close_accepted_connection(c);  
    70. 戻る;  
    71. }
    72. }
    73. }  
    75. *log = ls->log;  
    76. //初化新的接続
    77. c->recv = ngx_recv;  
    78. c->send = ngx_send;  
    79. c->recv_chain = ngx_recv_chain;  
    80. c->send_chain = ngx_send_chain;  
    82. c->log = log;  
    83. c->pool->log = log;  
    85. c->socklen = socklen;  
    86. c->listening = ls;  
    87. c->local_sockaddr = ls->sockaddr;  
    89. c->unexpected_eof = 1;  
    91. #if (NGX_HAVE_UNIX_DOMAIN)
    92. if (c->sockaddr-&g t;sa_family == AF_UNIX) {
    93. c->tcp_nopush = NGX_TCP_NOPUSH_DISABLED;  
    94. c->tcp_nolay = NGX_TCP_NODELAY_DISABLED;  
    95. #if (NGX_SOLARIS)
    96. /* Solaris の sendfilev() は AF_NCA、 AF_INET、および AF_INET6 をサポートしています */
    97. c->sendfile = 0;  
    98. #endif
    99. }
    100. #endif
    102. rev = c->read;  
    103. wev = c->write;  
    105. wev->ready = 1;  
    107. if (ngx_event_flags & (NGX_USE_AIO_EVENT|NGX_USE_RTSIG_EVENT)) {
    108. /* rtsig, aio, iocp */
    109. rev->ready = 1;  
    110. }
    112. if (ev->deferred_accept) {
    113. rev->ready = 1;  
    114. #if (NGX_HAVE_KQUEUE)
    115. rev->available = 1;  
    116. #endif
    117. }  
    119. rev->log = log;  
    120. wev->log = log;  
    122. /*
    123. * TODO: MT: - ngx_atomic_fetch_add()
    124. * または クリティカルセクションまたはライトミューテックスによる保護
    125. *
    126. * TODO: MP: - 共有メモリに割り当てられています
    127. * - ngx_atomic_fetch_add()
    128. * またはクリティカルセクションまたはライトミューテックスによる保護
    129. */
    131. c->number = ngx_atomic_fetch_add(ngx_connection_counter, 1);  
    133. if (ngx_add_conn && (ngx_event_flags & NGX_USE_EPOLL_EVENT) == 0) {
    134. if (ngx_add_conn(c) == NGX_ERROR) {
    135. ngx_close_accepted_connection (c);  
    136. 戻る;  
    137. }
    138. }
    140. log->data = NULL;  
    141. log->handler = NULL;  
    143. /*
    144. このリスン ハンドラー重要、新しい接続の最後の初期化作業を完了します，
    145. 同時に受け入れられた新しい接続がepollに投入されます中；挂在このハンドラー上の関数，
    146. 就是ngx_http_init_connection 在之后http模块中在详细介绍
    147. */
    148. ls->handler(c);  
    150. if (ngx_event_flags & NGX_USE_KQUEUE_EVENT) {
    151. ev-> ;利用可能--;  
    152. }
    154. } その間 （EV->利用可能）;  
    155. }
    
    accpt イベントのハンドラー メソッドもこのとおりです。その後は、各接続のコメント イベント ハンドラー メソッドであり、この部分は http モジュールに直接導入されます。更要学习下nginx经典模块epoll。

    上記は、nginx ソース コード学習ノート (21) - イベント モジュール 2 - イベント駆動型コア ngx_process_events_and_timers をキューの内容も含めて紹介しています。PHP チュートリアルに興味のある友人に役立つことを願っています。