nginx 原始碼學習筆記（二十一）－ event 模組二 －事件驅動核心ngx_process_events_and_timers

首先繼續回憶下，之前子執行緒執行操作裡面有一個未涉及的內容ngx_process_events_and_timers，今天我們就來研究下這個函數。

這篇文章來自於：http://blog.csdn.net/lengzijian/article/details/7601730

先來看看第十九節

今天主要講解的就是事件驅動函數，圖中的紅色部分：

[cpppp plaincopyprint?

1. src/event/ngx_event.c  
2.   
3. timers(ngx_cycle_t *cycle)  {  
4.     ng
    ngx_msec_t  timer, delta;  
  
  
7.         timer = NGX_TIMER_INFINITE;  
8.     
9.     } else  {  
10.         timer = ngx_event_find_timer();  _TIME;  
11.     }  
12.           ngx_use_accept_mutex變數代表是否使用accept互斥體
 
13.     預設使用，可透過accept_mutex off;指令關閉； 
    */
16.     
if
17.  (ngx_use_accept_mutex) {           
/*
18.  
        ngx_accept_disabled變數在ngx_event_accept函數中計算。
19.  
        如果ngx_accept_disabled大於0，並表示此程序接受的連結過多，
20.  同時將自己減一。  
21.         然後，並繼續處理已連結上的事件。  
22.         nginx利用這一點實現了繼承關於連接的基本負載平衡。          */
23.    0) {  
24.             ngx_accep t_disable  else
25.  {  
            
26. /* 
27.     
28.             因此，而確保了只有一個程序擁有監聽套接口，故   才不會驚群現象。 
29.             */    (ngx_trylock_accept_mutex(cycle) == NGX_ERROR) {  
30.                      }  
31.                if
 (ngx_accept_mutex_held) {   
32. /* 
33.                 
 
34.           ‧  
35.                 因為，以處理時間可能會很耗時，且不先施放鎖、除霸鎖             導致其他流程無法取得鎖定，且有accept的效率就低了。  
36.                 */     flags |= NGX_POST_EVENTS;  
37.       
38.                 /* 
39.    所得進程，當然不需要NGX_POST_EVENTS標誌。  
40.                 但為要設定延遲時多久，且再去爭搶。 
41.                 */     if
 (timer == NGX_TIMER_INFINITE  
42.          
43.                 {   accept_mutex_delay;  
44.                 }  
45.             }  
46.         }  
47.     }  
48.   
49.     delta = ngx_current_msec;  
50.       
51.     
/*接下來，epoll要開始wait事件，
52.  
53.     ngx_process_events的具體實作是對應epoll模組中的ngx_epoll_process_events函數 之後🠎
54.     */  
55.     (void
) ngx_process_events(cycle, timer, flags);  
56.      delta = ngx_current_msec - delta;  
57.       ngx_log_debug1 (NGX_LOG_DEBUG_EVENT, cycle->log, 0,  
58.                  
59.     
/*
60.  
post
61. 佇列，暫存epoll從監聽套介面wait到的accept事件。
 
62.     前文提到的NGX_POST_EVENTS標誌使用後，將所有的accept事件暫存到這個隊列
 
64.     if (ngx_posted_accept_events ) {  
65.         ngx_event_process_posted(cycle, &ngx_posted_accept_eventH);     //所有accept事件處理完後，如果持有鎖的話，就釋放掉。  
66.     if (ngx_accept_mutex_held) &ngx_accept_mutex);  
67.     }  
68.           delta是之前統計的耗時，存在毫秒級的耗時，就對所有時間的timer進行檢查，
 
70.     如果timeout 就從time rbtree中刪除到期的timer，同時調用相應事件的handler函數處理相應事件的handler函數處理？     */
71.   
    
72. if (delta) {  
73.         ngx_event_expire_timers();      }  
74.       ngx_log_debug1(NGX_LOG_DEBUG_EVENT, cycle-> log, 0,  
75.                    》,ed 
  
    
77. /* 
78.     處理普通事件中所獲得的寫字事件)，
 
79.     因為每個事件都有自己的handler方法， 
80.    if
81.  (ngx_posted_events) {  
        
82. if  (ngx_threaded) {  
83.             ngx_wakeup_worker_thread(cycle);  
  
84.         } else {  
85.             ngx_event_process_posted(cycle, &ngx_posted_events);  
        }  
86. }  
}  
88. 之前有說過accept事件，其實他就是監聽套介面上是否有新來的事件，下面介紹下accept時間的
89. [cpp] view plaincopyprint?
    1. src/event/ngx_event_accept.c  
    2.   
    3. void x_event_t * ev)  
    {  
        socklen_t     
    5.     ngx_err_t           ngx_socket_t       s；  
    6.     ngx_event_t         *ls;  
    7.     ngx_connection_t  *c， *lc；  
    8.     ngx_event_conf_t  *ecf；  
    9.     u_char          
    10.     //省略部分代碼
    11.    
    12.     ls = lc->聽；  
    13.     ev->準備=0；  bug2(NGX_LOG_DEBUG_EVENT, ev->log, 0,  
    14.               , 準備：%d"
    15. ，&ls->addr_text，ev->可用）；  
    16.            socklen = NGX_SOCKADDRLEN;  
    17.         / /接受一個新的連線
      
    19.         s = accept(lc->fd, (
            
    20. //簡潔部分程式碼  
              
            
    23.  重新計算ngx_accept_disabled的值，           主要是為了做負載平衡，且之前有提及。
     
    25.                    「連接數八分之一   -   剩餘的連結數「
     
    27.        指每個行程設定的再最大連線數，這個數字可以設定檔中指定。
     
90.          
91.     
92.          
93.         
94.         ngx_accept_disabled                        - ngx_cycle->free_connection_n;          
//取得connection
95.   
96.         c= ngx_get_connection(s, ev->log);  
97.   
98.                //連接關閉的時候，才釋放pool
100.   
101.         c->pool =     if (c->pool == NULL) {  
102. ngx_close_accepted_connection(c);              return🎠 
103.   
104.         c->sockaddr = ng   if
105.  (c->sockaddr == NULL) {              ngx_close_accepted_connection(c);  
106.             return
107. ;          }  
108.   
109.         ngx_memcpy(c->sockaddr , sa, socklen);  
110.   
111.         log         if
112.  (log == NULL) {  
113.             ngx_close_accepted_connection(c);    
114.         }
115.   
116.         /* 為aio設定阻塞模式，並設定非阻塞模式        if
 (ngx_inherited_nonblocking) {  
118. if (ngx_event_flags & NGX_USE_AIO_EVENT) {  
119.      == -1) {                       
                                 
120. 「失敗」）；  
                                   
121. 回復；  
122.                }  
  
123.  
 {  
124.             //我們使用epoll      if
125.  (!(ngx_event_flags & (NGX_USE_AIO_EVENT|NGX_USE_RTSIG_EVENT))) {                  if
126.  (ngx_nonblocking(s) ==         ngx_log_error(NGX_LOG_ALERT, ev-> ;log, ngx_socket_errno,  
         ngx_nonblocking_n 
127. 「失敗」);  
128.                     ngx_close_accepted_connection(c);  🎠  回；  
129.                 
        }
130.   
131.         *log = ls->log;   
132.         c->recv = ngx_recv;  
  ngx_send;  
        c->recv_chain = ngx_recv_chain;  
134.  
135.   
136.         c->log = log;  = log;  
137.   
138.         c->socklen = s   
139.         c->local_sockaddr = ls->sockaddr;    
  
140.         c->unexpected_eof = 1;  
141.   
142. 🎠         
if
143. （c->sockaddr->sa_家 == AF_UNIX) {  
144.             c->tcp_nopush = NGX_TCP_NOPUSH_DISABLED；  
_NODELAY_DISABLED;  
146. #if (NGX_SOLARIS)  
147. _INET及AF_INET6 */   
148.             c->sendfile =         }  
149. #endif  
150.         rev = c->閱讀；  
151.         wev =       我們->準備= 1;    
152.        (NGX_USE_AIO_EVENT|NGX_USE_RTSIG_EVENT)) {              /* rtsig、 aio、 iocp */
153.   
154.             rev->就緒= 1;          }  
155.   
156.          if (ev->deferred_accept) {  
157.             轉速UE)
  
159.             rev->可用 = 1;  
#endif
161.   
162.         }
163.   
164.         rev->log = log;  
165.   
166.         /* 
167.  () 
168.          *                * 
169.          * TODO: MP: - 分配在共享記憶體中 * TODO: MP: - 分配在共享記憶體中 * TODO: MP: - 分配在共享記憶體中 
170.          *           - ngx_atomic_fetch_add()       或透過臨界區域或輕斥體保護 
171.          */       c->number = ngx_atomic_fetch_add (ngx_connection_counter, 1);  
          
172.    _flags & NGX_USE_EPOLL_EVENT) == 0) {  
173.         
174.                 ngx_close_accepted_connection  回；  
175.             }    
176.            
177.      
178.     ->handler = NULL;            
179.          這裡聽 handler 非常重要，它完成了新連結的最後一個初始化工作， 
        同時接受新的連結到epoll；掛在這個handler上的函數，
180.  
181.         就是ngx_http_init_connection */  
182.         ls->handler(c );  
183.   
184.         if
 (ngx_event_flags & NGX_USE_KQUEUE_EVENT) {  
186.             ev->ava不可以——；  
187.         }  
188.       } 
while
189. （ev->可用）;  
190. }  
191. accpt事件的handler方法就這樣了。之後就是每個連接的讀寫器事件handler方法，這部分會直接將我們引入http模組，我們不著急，還要學習下nginx經典模組epoll。

     以上就介紹了nginx 原始碼學習筆記（二十一）—— event 模組二 ——事件驅動核心ngx_process_events_and_timers，包括了隊列方面的內容，希望對PHP教程有興趣的朋友有所幫助。