频道导航

Memcached source code analysis (threading model)--reference

2019-02-25 Memcache 前端之家

前端之家收集整理的这篇文章主要介绍了Memcached source code analysis (threading model)--reference，前端之家小编觉得挺不错的，现在分享给大家，也给大家做个参考。

(thread.c):

Highlighter" data-iceapw="38" data-iceapc="49">

conn_queue_item {

sfd out of the;

init_state;

event_flags;

read_buffer_size;

is_udp;

to establish a connection fd

Highlighter" data-iceapw="27" data-iceapc="38">

conn_queue CQ;

conn_queue {

Highlighter" data-iceapw="75" data-iceapc="62">

{

* /

event_base base; * *

event

Highlighter" data-iceapw="32" data-iceapc="42">

{

sfd out of the;

State;

event event;

which;

* RBUF;

the status flag and read-write buf information

thread process:

Highlighter" data-iceapw="15" data-iceapc="13">

Highlighter" data-iceapw="14" data-iceapc="13">

Highlighter" data-iceapw="5" data-iceapc="7">

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

Highlighter" data-iceapw="13" data-iceapc="13">

thread_init all workers thread,look at the core code thread_init

Highlighter" data-iceapw="118" data-iceapc="113">

nthreads, event_base * {

(LIBEVENT_THREAD) * nthreads);

(threads) {

(i = 0; i

fds [2];

(pipe (fds)) {

(i = 1; i

Highlighter" data-iceapw="89" data-iceapc="79">

* me) {

(! me-> base) {

base = event_init ();

(! me-> base) {

notify_event,me-> notify_receive_fd,

base,& me-> notify_event);

(event_add (& me-> 0) == -1) {

new_conn_queue);

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

Highlighter" data-iceapw="79" data-iceapc="75">

fd, which, * arg) {

buf [1];

(read (fd,buf,1)! = 1)

(settings.verbose,> 0)

new_conn_queue);

(NULL! = item) {

sfd,item-> init_state,item-> event_flags,

read_buffer_size,item-> is_udp,me-> base);

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:

Highlighter" data-iceapw="74" data-iceapc="93">

SFD, init_state, event_flags

read_buffer_size, event_base * base) {

event,sfd,event_flags,event_handler, *) c);

event);

ev_flags = event_flags;

(event_add (& c-> event,0) == -1) {

(conn_add_to_freelist (c)) {

NULL;

Highlighter" data-iceapw="118" data-iceapc="138">

drive_machine (conn * c) {

stop =