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

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

WBOY

リリース： 2016-07-29 09:11:02

オリジナル

1717 人が閲覧しました

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

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

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

nginx 源码学习笔记（二十一）—— event 模块二 ——事件驱动核心ngx_process_events_and_timers

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

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

src/event/ngx_event.c
void
ngx_process_events_and_timers(ngx _cycle_t *サイクル)
{
ngx_uint_t フラグ
ngx_msec_t タイマー、デルタ;
(ngx_timer_resolution) { 時間 r = NGX_TIMER_INFINITE ;
} 他の
タイマー = ngx_event_find_timer();
フラグ = NGX_UPDATE_TIME } /*
を使用するかどうかを表します
はデフォルトで使用され、accept_mutex off コマンドを使用してオフにできます。
ngx_accept_disabled 変数は ng で計算されます。 x_event_accept 関数。
ngx_accept_disabled が 0 より大きい場合、プロセスが受け入れるリンクが多すぎることを意味します。
したがって、受け入れミューテックスを獲得するために競合する機会を放棄し、自分自身を 1 つ減らします。
次に、既存の接続でイベントの処理を続けます。
nginx はこれを利用して、継承された接続の基本的な負荷分散を実装します。
ngx_accept_disabled-- ;
/* ミューテックスのロックを正常に取得した場合にのみ、Listen は EPOLL にワードを入れることができます。
したがって、これにより、1 つのプロセスだけが listen ソケットを持つことが保証されるため、すべてのプロセスが epoll_wait でブロックされた場合でも、
はグループパニックを引き起こしません。
プロセスがロックを取得すると、NGX_POST_EVENTS フラグが追加されます。
このフラグの機能は、生成されたすべてのイベントをキューに入れ、イベントが解放された後にゆっくりと処理することです。 - - 処理される、処理されるなど。効率は低い。 ️
} else{
ただし、ロックを争う前に遅延時間を設定する必要があります。
*/
(タイマー == ngx_timer_infinite
|| タイマー & gt; ex_dlay) {
タイマー = ngx_acceth_mutex_lay
delta = ngx_current_msec;
ngx_process_events の具体的な実装epoll モジュールの ngx_epoll_process_events 関数に対応します
*/
( void
/ / 統計この待機イベントの消費時間
delta = ngx_current_msec-delta
ngx_log_debug1(NGX_LOG_DEBUG_EVENT,cycle->log, 0,
/*
queue であり、リッスンソケットからの受け入れイベント epoll 待機を一時的に保存します。
キューに一時的に保存されます
if
ngx_event_process_posted(cycle, &ngx_posted_accept_events);
} //すべての受け入れイベントが処理された後、ロックが保持されている場合は解放します。
if (ngx_accept_mutex_held) {
ngx_shmtx_unlock(&ngx_accept_mutex) }
/*
デルタは前です統計的に時間がかかる場合は、ミリ秒レベルの時間がかかる場合は、すべての時刻のタイマーを確認します。
タイムアウトの場合は、時間切れのタイマーを時間 rbtree から削除し、そのハンドラー関数を呼び出します。処理する対応するイベント
*/
if
ngx_event_expire_timers();
/*
通常のイベントの処理 (接続イベントで取得されたデータの読み取りおよび書き込み)、
各イベントには独自のハンドラーメソッド、
*/
if
(ngx_posted_events) {
if (ngx_threaded) {
} }
受け入れイベントについては以前お話しましたが、実際には、ソケット上に新しいイベントがあるかどうかを監視します。受け入れ時のハンドラーメソッド:
[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
44. //接続が閉じられた場合にのみ解放 pool
46. if (c->pool == NULL ) {
48. ）; ;
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 チュートリアルに興味のある友人に役立つことを願っています。