广告合作QQ：76874919

• 首页
• 技术问答
• 编程语言
• 前端开发
• 移动开发
• 开发工具
• 程序设计
• 行业应用
• CMS系统
• 服务器
• 数据库
• 面试题
• 菜鸟教程
• 操作系统

 worker threads if MT mode * / 

 encapsulates create listening socket bound address,set the non-blocking mode and register the listening socket   

  thread_init all workers thread,look at the core code thread_init 

  nthreads,  event_base *  {
1.     
2.  (LIBEVENT_THREAD) * nthreads);
3.  (threads) {
7.   
10.   
11.  (i = 0; i
12.  fds [2];
13.  (pipe (fds)) {
17.   
20.   
23.   
24.  
25.  (i = 1; i

   * me) {
1.  (! me-> base) {
2. base = event_init ();
3.  (! me-> base) {
8.   
9.  
10. notify_event,me-> notify_receive_fd,
12. base,& me-> notify_event);
13.   
14.  (event_add (& me->  0) == -1) {
18.   
19. new_conn_queue);

   all workers thread pipe read end the libevent of read events,wait for the main thread last all workers CQ initialization     

    fd,  which,  * arg) {
3.  buf [1];
4.   
5.  (read (fd,buf,1)! = 1)
6.  (settings.verbose,> 0)
8.   
9. new_conn_queue);
10.   
11.  (NULL! = item) {
12. sfd,item-> init_state,item-> event_flags,
13. read_buffer_size,item-> is_udp,me-> base);
14.     

  SFD is already established connection descriptor,by conn_new function of the descriptor registration the libevent read event,me-> Base on behalf of a thread structure,that is the descriptor event processing the to this workersThreading,the most important elements of conn_new method is: 

   SFD,    init_state,    event_flags
1.    read_buffer_size,     event_base * base) {
2.   
3. event,sfd,event_flags,event_handler,  *) c);
4. event);
5. ev_flags = event_flags;
6.  (event_add (& c-> event,0) == -1) {
7.  (conn_add_to_freelist (c)) {
11.  NULL;
13.   

   drive_machine (conn * c) {
1.  stop = 
2.  SFD,flags = 1;
4.  sockaddr_storage addr;
5.  res;
6.   
8.   
9.  (! stop) {
10.   
11.  (c-> state) {
13.  (addr);
14.  ((sfd = accept (c-> sfd,  sockaddr *) & addr,& addrlen)) == -1) {
15.  
18.  ((flags = fcntl (sfd,  0)) <0 | |
27.   
29.  (try_read_command,(c) = 0) {
32.  

 conn_states to {
1.  
2.  
3.  
4.  
5.  
6.  
7.  

  sfd,    
1.  read_buffer_size,  {
3.    =  + 1)% 
4.   
6.   
7. sfd = sfd;
8. init_state = init_state;
9. event_flags = event_flags;
10. read_buffer_size = read_buffer_size;
11. is_udp = is_udp;
12.   
13.  new_conn_queue,item);
14.   
15.  Thread_id);
16.  (write (threads   1)! = 1) {