Memcached source code analysis (threading model)--reference

Memcache 2019-02-25

      (thread.c): 

     
  1.   
  2.  conn_queue_item {
  3.  sfd out of the;
  4.  init_state;
  5.  event_flags;
  6.  read_buffer_size;
  7.  is_udp;

 to establish a connection fd 

     
  1.    conn_queue CQ;
  2.  conn_queue {

 

       {
  1.  * / 
  2.  event_base  base;  *  *  
  3.     event  
  4.   
  5.   
  6.  

   

       {
  1.  sfd out of the;
  2.  State;
  3.  event event;
  4.  which;
  5.  * RBUF;
  6.  the status flag and read-write buf information 

  thread  process:  

     

 

     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) {

       

相关文章

缓存穿透，缓存雪崩的四种解决方案
前言设计一个缓存系统，不得不要考虑的问题就是：缓存穿透、...
Memcache安装
在192.168.80.100要联网关闭防火墙及SElinuxsystemctlstopfi...
redis -memcahe
Redis与Memcache对比：1.Memcache是一个分布式的内存对象缓存...
Mencache安装及实验
安装Mencache：关闭防火墙及SElinuxsystemctl  stop  fi...
php安装yaf，memcache，memcached模块
#安装php的yaf模块，参考https://www.cnblogs.com/shifu204/...
windows下安装配置apache、php、mysql、redis、memcache
win10下安装配置apache、php、mysql、redis、memcache资源官...