Memcached source code analysis (threading model)--reference

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

???????

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!