nginxソースコード学習メモ(20) - イベントモジュール1 - 初期化

これまでの学習ノートを読んだ後、nginx の起動プロセスをある程度理解できたと思います。このセクションからは、各モジュールを深く掘り下げて、各モジュール内の主な操作を学びたいと思います。

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

今日は、前回の起動で、各モジュールを多数呼び出すことについて説明しました。

のフック関数 このメソッドは主に ngx_event_conf_t 構造体を作成し、メモリ空間を割り当てます。

2. 設定ファイルを読み取ります:

たとえば、読み取られたファイルには次の行があります:

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

イベント

{

epoll を使用します

1. }
2. この場所でのイベントはブロック命令です。命令は括弧内で設定できます。これらの命令は src/event/ngx_event.c
3. [cpp] ビューで定義されています。 普通のコピープリント？
5. static ngx_command_t ngx_event_core_commands[] = {

{ ngx_string(

"worker_connections"

) 、

1. NGX_EVENT_CONF|NGX_CONF_TAKE1、 ngx_event_connections ,
2. 0,
3. 0, NULL },
4. ...(ここでは省略)
6. { ngx_string(
「接続」
7. ),
8. NGX_EVENT_CONF|NGX_CONF_TAKE1、
9. ngx_event_connections、
10. 0、
11. 0、 NULL }、
13. {ngx_string(
"使用"
14. ) )、
15. NGX_EVENT_CONF|NGX_CONF_TAKE1、
16. ngx_event_use、
17. 0、
18. 0、 NULL }、
19. ngx_null_command
20. };
21. イベントが解析されると、次の関数がコールバックされます:
22. [cpp] view 普通のコピープリント？
23. 1. src/event/ngx_event.c
    2. static char *
    3. ngx_events_block(ngx_conf_t *cf, ngx_command_t *cmd, void *conf)
    4. {
    5. char *rv;  
    6. void ***ctx;  
    7. ngx_uint_t i;  
    8. ngx_conf_t pcf;  
    9. ngx_event_module_t *m;  
    11. /* イベントモジュールの数を数え、インデックスを設定します */
    12. //计算event模块数，并そして记录
    13. ngx_event_max_module = 0;  
    14. for (i = 0; ngx_modules[i]; i++) {
    15. if (ngx_modules[i]->type != NGX_EVENT_MODULE) {
    16. 続けます;  
    17. }
    19. ngx_modules[i]->ctx_index = ngx_event_max_module++;  
    20. }
    22. ctx = ngx_pcalloc(cf->pool, sizeof(void *));  
    23. if (ctx == NULL) {
    24. return NGX_CONF_ERROR;  
    25. }
    26. //のために每一イベント模块割り当て空間、保存用响应配置结构的地址
    27. //共割了ngx_event_max_module个空间
    28. *ctx = ngx_pcalloc(cf->pool, ngx_event_max_module * sizeof(void *));  
    29. if (*ctx == NULL) {
    30. return NGX_CONF_ERROR;  
    31. }
    33. *(void **) conf = ctx;  
    35. for (i = 0; ngx_modules[i]; i++) {
    36. if (ngx_modules[i]->type != NGX_EVENT_MODULE) {
    37. 続きます;  
    38. }
    40. m = ngx_modules[i]->ctx;
    if
    42. (m->create_conf) { (*ctx)[ngx_modules[i]->ctx_index] = m->create_conf(cf->cycle);
    ((*ctx)[ngx_modules[i]->ctx_index] == NULL) {
    45. pcf = *cf->ctx = ctx; cf->module_type = NGX_EVENT_MODULE
    46. cf-> ;cmd_type = NGX_EVENT_CONF;
    47. //イベントはブロック命令であるため、他の多くの命令をイベント ドメインで構成できます。 、ここでイベント ブロック内の命令の解析を開始し、初期化作業を完了します。
    49. rv = ngx_conf_parse(cf, NULL);
    50. *cf = pcf; if
    (rv != NGX_CONF_OK)
    52. if
    53. （ngx_modules [i] - ＆gt; type！= ngx_event_module）{
    54. m= ngx_modules [ i] - ＆gt; ctx;//各イベントを実行するModuleのinit_conf関数は、「 ' to ' to use ' to ' to ' t d to d. t;init_conf(cf->cycle, (*ctx) [ngx_modules[i]->ctx_index]);
    55. }
    56. }
    57. 
        

        ngx_events_block() 関数の最も重要なプロセスは、ngx_conf_parse(cf, NULL) を呼び出すことです。ここで ngx_conf_parse() を呼び出す関数は、設定ファイル内の events ブロックの解析を完了し、それによってすべてのイベントを呼び出します。命令のコールバック関数により、構成ファイルの解析の初期化が完了します。しかし、ここで個人的な質問がありますので、先輩方に質問した後、質問と回答を明記します******。

        2. confの初期化(init_conf)

        ngx_event_init_conf()
        

        このメソッドは主にngx_event_conf_t構造体を初期化します。
        

        3.ngx_event_module_init

        名前からするとモジュールの初期化操作ですが、各モジュールのソースコードを見るとinitコールバック関数を持たないモジュールが多いことが分かります。私も、すべてのコードを学習した後に答えを見つけたいと思っているので、なぜここにあるのか悩んでいます。

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

        1. src/event/ngx_event.c
        2. static ngx_int_t
        3. ngx_event_module_init(ngx_cycle_t *cycle)
        4. {
        5. void ***cf;  
        6. u_char *共有;  
        7. size_t サイズ、cl;  
        8. ngx_shm_t shm;  
        9. ngx_time_t *tp;  
        10. ngx_core_conf_t *ccf;  
        11. ngx_event_conf_t *ecf;  
        13. // 判断ngx_events_module かどうか调用过初期化conf操作
        14. cf = ngx_get_conf(cycle-> conf_ctx、ngx_events_module);  
        16. if (cf == NULL) {
        17. ngx_log_error(NGX_LOG_EMERG, cycle->log, 0、
        18. 「設定に「イベント」セクションがありません」 );  
        19. return NGX_ERROR;  
        20. }
        22. //获取ngx_event_core_module模块の構成结构
        23. ecf = (*cf)[ngx_event_core_module.ctx_index];  
        25. //イベント内のモジュールであるかどうかを確認します。たとえば、使用します。。。。
        26. if (!ngx_test_config && ngx_process
        27. ngx_log_error(NGX _LOG_NOTICE, サイクル->ログ, 0 ,
        28. 「イベントメソッド」 , ecf->name);
        29. }
        30. //ngx_core_module モジュールの構成構造を取得します
        ccf = (ngx_core_conf_t *) ngx_ get_conf(cycle- >conf_ctx, ngx_core_module);
        // ngx_core_module モジュールの構成構造体から timer_resolution パラメータを取得します ngx_timer_resolution = ccf->timer_resolution;
        34. #if !(NGX_WIN32)
        35. {
        36. ngx_int_t 制限
        37. rlimit rlmt; //現在のプロセスの能力を取得します 開いているファイルの最大数 man getrlimit
        38. （getrlimit（rlimit_nofile、＆rlmt）== -1）{
        39. ngx_log_error（ngx_log_alert、cycle-＆gt; log、ngx_errno、else{
        40. _モジュールへの最大接続数は無制限です
        41. / / または ngx_event_core_module 接続が ngx_core_module の最大接続数より大きいです
        42. (ECF-& GT; 接続 & GT; (ngx_uint_t) rlmt.rlim_cur
        43. (ccf-& gt; _NOFILE == ngx_conf_unset)
        limit = (ccf ->rlimit_nofile == NGX_CONF_UNSET) ?
        (ngx_int_t) rlmt.rlim_cur: ccf- & gt;
        46. " オープンファイルのリソース制限: %i" ); (NGX_WIN32) */
        49. //マスタープロセスが閉じている場合は、 return
        51. //マスタープロセスを閉じることは単一プロセスの作業メソッドを意味するため、
        52. //後続の操作では、ロックやその他の作業を実装するための共有メモリが作成されますが、これは単一プロセスには必要ありません。
    58. if (ccf->master == 0) {
    59. NGX_OK }
    // 受け入れミューテックスの場合すでに存在するため、再度作成する必要はありません。
    62. } /* cl はキャッシュ以上である必要がありますline size */
    64. cl = 128; // ここでサイズを作成します。この共有メモリは 3 つの等しいセグメントに分割されます
    66. サイズ= cl + cl ,
    68. shm.size = サイズ shm.name.len = sizeof
    (
    69. 「nginx_shared_zone」
    ); shm.name.data = (u_char *)
    70. "nginx_share d_zone";
    71. shm.log = サイクル->log
    72. (ngx_shm_alloc(&s)うーん) = NGX_OK ) {
    73. NGX_ERROR;
    75. ; .addr;
    76. //ミューテックスの取得を受け入れる共有メモリの最初の cl サイズメモリ
    77. ngx_accept_mutex_ptr = (ngx_atomic_t *) 共有メモリ
    78. ngx_accept_mutex.spin = (ngx_uint_t) -1; /* 受け入れミューテックスを作成します
    79. 受け入れミューテックスの実装は、アトミック操作をサポートするかどうか、および対応するアトミック操作があるかどうかによって異なります。 ; それ以外の場合は、受け入れミューテックスを実装するためにファイル ロックが使用されます。
    81. accept mutex の機能は、パニック グループを回避し、ワーカー プロセスの負荷分散を実現することです。
    83. */ngx_accept_mutex、共有、cycle-＆gt; lock_file.data）
    84. ！= ngx_ok） //メモリの 2 番目のセグメントの cl サイズのアドレスを取得します
    85. ngx_connection_counter = (ngx_atomic_t *) (shared + 1 * cl)
    86. (void
    ); ngx_atomic_cmp_set (ngx_connection_counter, 0, 1);
    87. ngx_log_debug2(NGX_LOG_DEBUG_EVENT, サイクル - >log, 0,
    88. x_connection_counter);
    89. //メモリ cl アドレスの 3 番目のセグメントのサイズを取得します。
    90. ngx_temp_number = (ngx_atomic_t *) (shared + 2 * cl)
    91. tp = ngx_timeofday() ;
    92. ngx_random_number = (tp-> ; msec
    93. returnNGX_OK; 前述したように分析では、ワーカー プロセスが作成されると、ワーカー プロセスは最初にプロセスを初期化し、この時点で ngx_event_process_init 関数が呼び出されます。
    94. [cpp]ビュー 普通のコピープリント？
    1. src/event/ngx_event.c
    2. staticngx_int_t
    3. ngx_event_process_init(ngx_cycle_t *cycle)
    4. {
    5. ngx_uint_t m、私; ngx_event_t *rev、*wev;
    6. ngx_listening_t *ls;
    7. ngx_connection_t *c、*next、*old
    8. ; ngx_event_conf_t *ecf;
    9. ngx_event_module_t *module;
    11. //前と同様に、応答モジュールの構成構造を取得します
    ccf = (ngx_core_conf_t *) ngx_get_conf(cycle->conf_ctx, ngx _コア_モジュール);
    13. ecf = ngx_event_get_conf(cycle->conf_ctx, ngx_event_core_module);
    //マスタープロセスがオープン、ワーカープロセスが1より大きい、accept_mutexが作成されました
    //cai accept mutex を開きます
    if
    18. (ccf->master &&ccf->worker_processes > 1 &&ecf->accept_mutex) { ngx_use_accept_mutex = 1; / /ミューテックスを使用する
    19. ngx_accept_mutex_held = 0; //受け入れミューテックスを取得するかどうか
    20. ngx_accept_mutex_lay = ecf->accept_mutex_lay; //ミューテックスの競合に失敗した後、待機中次のスクランブル時間間隔用
    22. } else {
    23. ngx_use_accept_mutex = 0 ;
    }
    25. #if (NGX_THREADS )
    27. //スレッドはさておき
    28. #endif
    29. // カウンターを初期化する、ここに赤が作成されます Black Tree、タイマー、後で詳しく説明します
    30. if (ngx_event_timer_init(cycle->log) == NGX_ERROR) {
    31. return NGX_ERROR;
    32. }
    33. for (m = 0; ngx_modules[m]; m++) {
    34. //前にここで述べたように、非 NGX_EVENT_MODULE モジュールをスキップします
    36. }
    37. // 使用しない構成命令で指定されたモジュールはスキップされます。Linux のデフォルトの epoll です。 ->use) { module = ngx_modules[m]->ctx;
    /*init を呼び出します特定の時間モジュールの関数
    38. (これらのモジュールは src/event/modules ディレクトリにあります)。したがって、nginx の時間モジュールに抽象化のレイヤーが作成されており、これにより、さまざまなシステムがさまざまなイベント モデルを使用しやすくなり、新しい時間モデルを拡張します。私たちは epoll に重点を置く必要があります。
    41. は、実際には ngx_epoll_init 関数を呼び出しています。 module->actions 構造は、epoll のすべてのインターフェイス関数をカプセル化します。 nginx は、アクション構造を通じて epoll をイベント抽象化レイヤーに登録します。
    42. アクションのタイプは、src/event/ngx_event.h にある ngx_event_action_t です
    43. これらの具体的な内容については、次のセクションで説明します。
    44. module->actions.init(cycle, ngx_timer_resolution) != NGX_OK) {
    45. *faタル */
    exit(2)
    46. Break;
    47. }
    48. //内容の一部
    //すべての接続を保存するグローバル ngx_connection_t 配列を作成します
    51. //この処理は各ワーカープロセスで実行されるため、各ワーカーは独自の接続配列を持ちます
    52. cycle->connections =
    53. ngx_alloc(sizeof(ngx_connection_t) *cycle->connection_n 、サイクル>ログ);
    54. if (サイクル>接続 == NULL) {
    55. c = サイクル>接続; 创/ // 読み取り値のグループを作成します。
    56. if
    57. (cycle->read_events == NULL) { }
    58. rev =cycle->read_events;
    59. for (i = 0; i connection_n; i++) {
    60. rev[i].closed = 1 ;
    61. [i].instance = 1;
    62. #if (NGX_THREADS)
    63. rev[i].lock = &c[i].lock
    64. rev[ i].own_lock = &c[i].lock
    #endif
    65. }  
    66. //创建一写イベント数组
    67. cycle->write_events = ngx_alloc(sizeof(ngx_event_t) * cycle-& gt;connection_n、
    68. cycle->ログ）;  
    69. if (cycle->write_events == NULL) {
    70. return NGX_ERROR;  
    71. }
    73. wev = cycle->write_events;  
    74. for (i = 0; i connection_n; i++) {
    75. wev[i].closed = 1;  
    76. #if (NGX_THREADS)
    77. wev[i].lock = &c[i].lock;  
    78. wev[i].own_lock = &c[i].lock;  
    79. #endif
    80. }
    82. i = cycle->connection_n;  
    83. 次 = NULL;  
    84. //初化整个接続数组
    85. do {
    86. i--;  
    88. c[i].data = 次;  
    89. c[i].read = &cycle->read_events[i];  
    90. c[i].write = &cycle->write_events[i];  
    91. c[i].fd = (ngx_socket_t) -1;  
    93. next = &c[i];  
    95. #if (NGX_THREADS)
    96. c[i].lock = 0;  
    97. #endif
    98. } (i);
    99. サイクル->free_connection_n = サイクル->
    101. /* 各リスニング ソケット用 */
    103. //各リスニング ソケットの接続配列から接続、つまりスロット
    ls =cycle->listening を割り当てます。 els; solt
    104. に接続します c = ngx_get_connection(ls[i].fd,cycle->log)
    105. (c == NULL) {
    106. NGX_エラー }  
    108. c->log = &ls[i].log;  
    110. c->listening = &ls[i];  
    111. ls[i].connection = c;  
    113. rev = c->read;  
    115. rev->log = c->log;  
    116. rev->accept = 1; //读時間间発行，调用accept
    118. #if (NGX_HAVE_DEFERRED_ACCEPT)
    119. //省略
    120. #endif
    122. if (!(ngx_event_flags & NGX_USE_IOCP_EVENT)) {
    123. if (ls[i].previous) {
    125. /*
    126. * バインドされていた古い accept イベントを削除します
    127. * 古い サイクル 読み取り イベント 配列
    128. */
    130. old = ls[i].previous->connection;  
    132. if (ngx_del_event(old->read, NGX_READ_EVENT, NGX_CLOSE_EVENT)
    133. == NGX_ERROR)
    134. {
    135. return NGX _エラー;  
    136. }
    138. old->fd = (ngx_socket_t) -1;  
    139. }
    140. }
    142. //コールバック関数を登録します ngx_event_accept
    143. rev->handler = ngx_even t_accept;
    144. 当面はリスニングソケットを epoll に置かないでください。しかし、
    145. {{
    146. }}}
    eLSe
    147. {
    148. //使用した後、このリスニングソケットを epoll に置きます。 ️ #endif
    151. }
    152. return
    NGX_OK
    153. }
    154. ここまでで、イベント駆動型の初期化が完了しました。 以上、nginx ソースコード学習メモ (20) - イベント モジュール 1 - 初期化 (IOC とカウンターの内容を含む) を紹介しました。PHP チュートリアルに興味のある友人に役立つことを願っています。