memcached探索之thread model(2)-MySQL 튜토리얼-php.cn

집

데이터 베이스

MySQL 튜토리얼

memcached探索之thread model(2)

WBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWB

Jun 07, 2016 pm 03:11 PM

memcached model thread 아래에 나 탐구하다

6. 下面我们看看主线程dispatch_thread的事件处理设置。在memcached.c中的main函数中 /* create unix mode sockets after dropping privileges */ if ( settings . socketpath ! = NULL ) { errno = 0 ; if ( server_socket_unix ( settings . socketpath ,

6. 下面我们看看主线程dispatch_thread的事件处理设置。在memcached.c中的main函数中

/* create unix mode sockets after dropping privileges */ if (settings.socketpath != NULL) { errno = 0; if (server_socket_unix(settings.socketpath,settings.access)) { vperror("failed to listen on UNIX socket: %s", settings.socketpath); exit(EX_OSERR); } } /* create the listening socket, bind it, and init */ if (settings.socketpath == NULL) { int udp_port; const char *portnumber_filename = getenv("MEMCACHED_PORT_FILENAME"); char temp_portnumber_filename[PATH_MAX]; FILE *portnumber_file = NULL; if (portnumber_filename != NULL) { snprintf(temp_portnumber_filename, sizeof(temp_portnumber_filename), "%s.lck", portnumber_filename); portnumber_file = fopen(temp_portnumber_filename, "a"); if (portnumber_file == NULL) { fprintf(stderr, "Failed to open \"%s\": %s\n", temp_portnumber_filename, strerror(errno)); } } errno = 0; if (settings.port && server_socket(settings.port, tcp_transport, portnumber_file)) { vperror("failed to listen on TCP port %d", settings.port); exit(EX_OSERR); } /* * initialization order: first create the listening sockets * (may need root on low ports), then drop root if needed, * then daemonise if needed, then init libevent (in some cases * descriptors created by libevent wouldn't survive forking). */ udp_port = settings.udpport ? settings.udpport : settings.port; /* create the UDP listening socket and bind it */ errno = 0; if (settings.udpport && server_socket(settings.udpport, udp_transport, portnumber_file)) { vperror("failed to listen on UDP port %d", settings.udpport); exit(EX_OSERR); } if (portnumber_file) { fclose(portnumber_file); rename(temp_portnumber_filename, portnumber_filename); } } /* Drop privileges no longer needed */ drop_privileges(); /* enter the event loop */ event_base_loop(main_base, 0); //主线程(dispatcher_thread)的事件监听循环。。。

 

7. 继续跟踪server_socket函数（memcached.c中）

/** * Create a socket and bind it to a specific port number * @param port the port number to bind to * @param transport the transport protocol (TCP / UDP) * @param portnumber_file A filepointer to write the port numbers to * when they are successfully added to the list of ports we * listen on. */ static int server_socket(int port, enum network_transport transport, FILE *portnumber_file) { int sfd; struct linger ling = {0, 0}; struct addrinfo *ai; struct addrinfo *next; struct addrinfo hints = { .ai_flags = AI_PASSIVE, .ai_family = AF_UNSPEC }; char port_buf[NI_MAXSERV]; int error; int success = 0; int flags =1; hints.ai_socktype = IS_UDP(transport) ? SOCK_DGRAM : SOCK_STREAM; if (port == -1) { port = 0; } snprintf(port_buf, sizeof(port_buf), "%d", port); error= getaddrinfo(settings.inter, port_buf, &hints, &ai); if (error != 0) { if (error != EAI_SYSTEM) fprintf(stderr, "getaddrinfo(): %s\n", gai_strerror(error)); else perror("getaddrinfo()"); return 1; } for (next= ai; next; next= next->ai_next) { conn *listen_conn_add; if ((sfd = new_socket(next)) == -1) { //creat socket /* getaddrinfo can return "junk" addresses, * we make sure at least one works before erroring. */ continue; } #ifdef IPV6_V6ONLY if (next->ai_family == AF_INET6) { error = setsockopt(sfd, IPPROTO_IPV6, IPV6_V6ONLY, (char *) &flags, sizeof(flags)); if (error != 0) { perror("setsockopt"); close(sfd); continue; } } #endif //setsockopt
 setsockopt(sfd, SOL_SOCKET, SO_REUSEADDR, (void *)&flags, sizeof(flags)); if (IS_UDP(transport)) { maximize_sndbuf(sfd); } else { error = setsockopt(sfd, SOL_SOCKET, SO_KEEPALIVE, (void *)&flags, sizeof(flags)); if (error != 0) perror("setsockopt"); error = setsockopt(sfd, SOL_SOCKET, SO_LINGER, (void *)&ling, sizeof(ling)); if (error != 0) perror("setsockopt"); error = setsockopt(sfd, IPPROTO_TCP, TCP_NODELAY, (void *)&flags, sizeof(flags)); if (error != 0) perror("setsockopt"); } //bind if (bind(sfd, next->ai_addr, next->ai_addrlen) == -1) { if (errno != EADDRINUSE) { perror("bind()"); close(sfd); freeaddrinfo(ai); return 1; } close(sfd); continue; } else { success++;

//TCP listen if (!IS_UDP(transport) && listen(sfd, settings.backlog) == -1) { perror("listen()"); close(sfd); freeaddrinfo(ai); return 1; } if (portnumber_file != NULL && (next->ai_addr->sa_family == AF_INET || next->ai_addr->sa_family == AF_INET6)) { union { struct sockaddr_in in; struct sockaddr_in6 in6; } my_sockaddr; socklen_t len = sizeof(my_sockaddr); if (getsockname(sfd, (struct sockaddr*)&my_sockaddr, &len)==0) { if (next->ai_addr->sa_family == AF_INET) { fprintf(portnumber_file, "%s INET: %u\n", IS_UDP(transport) ? "UDP" : "TCP", ntohs(my_sockaddr.in.sin_port)); } else { fprintf(portnumber_file, "%s INET6: %u\n", IS_UDP(transport) ? "UDP" : "TCP", ntohs(my_sockaddr.in6.sin6_port)); } } } } if (IS_UDP(transport)) {

 //UDP 的处理中不需要accept,所以直接派发connection到工作线程。 int c; for (c = 0; c settings.num_threads; c++) { /* this is guaranteed to hit all threads because we round-robin */ dispatch_conn_new(sfd, conn_read, EV_READ | EV_PERSIST, UDP_READ_BUFFER_SIZE, transport); } } else {

//TCP的处理(注意，这里dispatcher_thread同样调用了conn_new来绑定conn_event到其main_base. 并且此时conn的初始状态为conn_listening, 事件为持久可读，而在conn_new中注册了conn_event的回调函数为event_handler,所以，dispatche_thread在当前listen的socket可读时就会调用event_handler,进而调用driver_machine(c) 进入状态机。而在driver_machine中如果是主线程(dispatcher_thread)则会在accept socket后调用dispatch_new_conn函数来给各worker_thread派发connection...) if (!(listen_conn_add = conn_new(sfd, conn_listening, EV_READ | EV_PERSIST, 1, transport, main_base))) { fprintf(stderr, "failed to create listening connection\n"); exit(EXIT_FAILURE); } listen_conn_add->next = listen_conn; listen_conn = listen_conn_add; } } freeaddrinfo(ai); /* Return zero iff we detected no errors in starting up connections */ return success == 0; }

8. 看看UDP和TCP模式下dispatcher_thread都会调用的dispatch_new_conn函数(在thread.c中)

/* * Dispatches a new connection to another thread. This is only ever called * from the main thread, either during initialization (for UDP) or because * of an incoming connection. */ void dispatch_conn_new(int sfd, enum conn_states init_state, int event_flags, int read_buffer_size, enum network_transport transport) { CQ_ITEM *item = cqi_new(); int tid = (last_thread + 1) % settings.num_threads; //轮询的方式找worker_thread LIBEVENT_THREAD *thread = threads + tid; last_thread = tid; item->sfd = sfd; item->init_state = init_state; item->event_flags = event_flags; item->read_buffer_size = read_buffer_size; item->transport = transport; //push conn到worker_thread的CQ中
 cq_push(thread->new_conn_queue, item); MEMCACHED_CONN_DISPATCH(sfd, thread->thread_id); if (write(thread->notify_send_fd, "", 1) != 1) { perror("Writing to thread notify pipe"); } }

9. 先看看unix domain socket模式下主线程的事件处理设置。（在上面的6中调用的 server_socket_unix函数）

static int server_socket_unix(const char *path, int access_mask) { int sfd; struct linger ling = {0, 0}; struct sockaddr_un addr; struct stat tstat; int flags =1; int old_umask; if (!path) { return 1; } if ((sfd = new_socket_unix()) == -1) { return 1; } /* * Clean up a previous socket file if we left it around */ if (lstat(path, &tstat) == 0) { if (S_ISSOCK(tstat.st_mode)) unlink(path); } setsockopt(sfd, SOL_SOCKET, SO_REUSEADDR, (void *)&flags, sizeof(flags)); setsockopt(sfd, SOL_SOCKET, SO_KEEPALIVE, (void *)&flags, sizeof(flags)); setsockopt(sfd, SOL_SOCKET, SO_LINGER, (void *)&ling, sizeof(ling)); /* * the memset call clears nonstandard fields in some impementations * that otherwise mess things up. */ memset(&addr, 0, sizeof(addr)); addr.sun_family = AF_UNIX; strncpy(addr.sun_path, path, sizeof(addr.sun_path) - 1); assert(strcmp(addr.sun_path, path) == 0); old_umask = umask( ~(access_mask&0777)); if (bind(sfd, (struct sockaddr *)&addr, sizeof(addr)) == -1) { perror("bind()"); close(sfd); umask(old_umask); return 1; } umask(old_umask); if (listen(sfd, settings.backlog) == -1) { perror("listen()"); close(sfd); return 1; } if (!(listen_conn = conn_new(sfd, conn_listening, //同样是调用conn_new EV_READ | EV_PERSIST, 1, local_transport, main_base))) { fprintf(stderr, "failed to create listening connection\n"); exit(EXIT_FAILURE); } return 0; }

본 웹사이트의 성명

본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.

핫 AI 도구

Undresser.AI Undress

사실적인 누드 사진을 만들기 위한 AI 기반 앱

AI Clothes Remover

사진에서 옷을 제거하는 온라인 AI 도구입니다.

Undress AI Tool

무료로 이미지를 벗다

Clothoff.io

AI 옷 제거제

AI Hentai Generator

AI Hentai를 무료로 생성하십시오.

뜨거운 도구

메모장++7.3.1

사용하기 쉬운 무료 코드 편집기

SublimeText3 중국어 버전

중국어 버전, 사용하기 매우 쉽습니다.

스튜디오 13.0.1 보내기

강력한 PHP 통합 개발 환경

드림위버 CS6

시각적 웹 개발 도구

SublimeText3 Mac 버전

신 수준의 코드 편집 소프트웨어(SublimeText3)

뜨거운 주제

Gmail 이메일의 로그인 입구는 어디에 있나요?

7449

Cakephp 튜토리얼

1374

Steam의 계정 이름 형식은 무엇입니까?

Win11 활성화 키 영구

NYT 연결 힌트와 답변

Related knowledge

Go 언어의 미래 개발 동향을 살펴보세요 Mar 24, 2024 pm 01:42 PM

제목: Go 언어의 미래 개발 동향 탐구 인터넷 기술의 급속한 발전과 함께 프로그래밍 언어도 끊임없이 진화하고 발전하고 있습니다. 그중 Go 언어(Golang)는 구글이 개발한 오픈소스 프로그래밍 언어로 단순성, 효율성, 동시성 기능으로 많은 사랑을 받고 있습니다. 점점 더 많은 기업과 개발자가 애플리케이션 구축에 Go 언어를 채택하기 시작하면서 Go 언어의 향후 개발 동향이 많은 주목을 받고 있습니다. 1. Go 언어의 특징과 장점 Go 언어는 가비지 수집 메커니즘을 갖춘 정적인 유형의 프로그래밍 언어이며,

캔버스 속성의 비밀을 밝히다 Jan 17, 2024 am 10:08 AM

캔버스 속성의 비밀을 탐색하려면 구체적인 코드 예제가 필요합니다. 캔버스는 HTML5의 매우 강력한 그래픽 그리기 도구를 통해 웹 페이지에 복잡한 그래픽, 동적 효과, 게임 등을 쉽게 그릴 수 있습니다. 하지만 이를 사용하기 위해서는 Canvas의 관련 속성과 메소드를 숙지하고 사용법을 익혀야 합니다. 이 기사에서는 Canvas의 핵심 속성 중 일부를 살펴보고 특정 코드 예제를 제공하여 독자가 이러한 속성을 사용하는 방법을 더 잘 이해할 수 있도록 돕습니다.

Trezor Cold Wallet: Model One 및 Model T 기능 및 사용 가이드 Jan 19, 2024 pm 04:12 PM

많은 중앙화된 거래소에서 문제가 발생한 후 점점 더 많은 통화 투자자들이 중앙화된 거래소에서 발생하는 위험을 줄이기 위해 자산을 콜드 지갑으로 이전하기 시작했습니다. 이 글에서는 세계 최초의 콜드월렛 제공업체인 Trezor를 소개하겠습니다. 2014년 최초의 콜드월렛이 출시된 이후 전 세계 여러 나라에서 판매되고 있습니다. Trezor의 제품에는 2014년에 출시된 Model One과 2018년에 출시된 고급 버전인 Model T가 포함됩니다. 다음에서는 계속해서 이 두 제품과 다른 콜드월렛의 차이점을 소개하겠습니다. Trezor 콜드월렛이란 무엇인가요? 2014년 Trezor는 최초의 콜드 지갑 ModelOne을 출시했습니다. 일반적인 BTC, ETH, USDT 및 기타 통화 외에도 지갑은 1,000개 이상의 다른 통화도 지원합니다.

Go 언어에서 일반적으로 사용되는 데이터베이스 선택 탐색 Jan 28, 2024 am 08:04 AM

Go 언어에서 일반적으로 사용되는 데이터베이스 선택 탐색 소개: 최신 소프트웨어 개발에서는 웹 애플리케이션, 모바일 애플리케이션, 사물 인터넷 애플리케이션 등 데이터 저장과 쿼리가 분리될 수 없습니다. Go 언어에는 뛰어난 데이터베이스 옵션이 많이 있습니다. 이 기사에서는 Go 언어에서 일반적으로 사용되는 데이터베이스 선택을 살펴보고 독자가 자신의 필요에 맞는 데이터베이스를 이해하고 선택하는 데 도움이 되는 특정 코드 예제를 제공합니다. 1. SQL 데이터베이스 MySQL MySQL은 인기 있는 오픈 소스 관계형 데이터베이스 관리 시스템입니다. 다양한 기능을 지원하며,

배낭을 메고 티베트 여행을 갑니다. ① 제가 가지고 다니는 가방은 몇 리터 정도가 적당하다고 생각하시나요? 저는 170인데 처음으로 체력이 좋습니다. Jan 07, 2024 am 10:06 AM

티베트로 배낭여행을 가려고 합니다. ① 가방은 몇 리터 정도 가지고 가는 것이 가장 좋은지 알려주세요. 170인데 체력이 처음이라 60 정도 들어갔습니다. 리터 이상. 전체 여행은 자동차로 이루어졌습니다. 배낭이 필요하지 않으면 25-40 리터의 여행 가방이 더 편리합니다. 티베트 여행에 필요한 물품: 선글라스, 선햇, 자외선 차단제, 스킨 크림, 립밤, 긴팔 상의, 특별한 여행이나 알리, 북부 티베트 및 쓰촨-티베트 노선 여행을 위한 스웨터. 지참 권장사항: 침낭(방한용품), 시트(더러움 방지용품), 다운 재킷, 여행용 신발 또는 등산화, 슬리퍼, 칫솔, 치약, 수건, 롤링페이퍼, 종이 속옷, 소독 물티슈, 손전등, 방수 성냥, 칼 , 로프. 컴퓨터를 앞가방에 넣을 수 있나요? 일부 백팩에는 컴퓨터를 넣을 수 있나요?

Go에서 그래프 프로그래밍 살펴보기: 그래프 API 구현 가능성 Mar 25, 2024 am 11:03 AM

Go 언어의 그래픽 프로그래밍 탐구: 그래픽 API 구현 가능성 컴퓨터 기술의 지속적인 발전으로 그래픽 프로그래밍은 컴퓨터 과학에서 중요한 응용 분야가 되었습니다. 그래픽 프로그래밍을 통해 다양하고 정교한 그래픽 인터페이스, 애니메이션 효과 및 데이터 시각화를 실현하여 사용자에게 보다 직관적이고 친숙한 대화형 경험을 제공할 수 있습니다. 최근 몇 년간 Go 언어의 급속한 발전으로 점점 더 많은 개발자들이 그래픽 프로그래밍 분야에서 Go 언어 적용에 관심을 돌리기 시작했습니다. 이 기사에서는 구현 방법을 살펴보겠습니다.

Linux 커널 소스 코드 배포에 대한 심층 탐구 Mar 15, 2024 am 10:21 AM

이것은 Linux 커널 소스 코드 배포를 심층적으로 탐구하는 1500 단어 분량의 기사입니다. 제한된 공간으로 인해 Linux 커널 소스 코드의 조직 구조에 중점을 두고 독자의 이해를 돕기 위해 몇 가지 구체적인 코드 예제를 제공합니다. Linux 커널은 소스 코드가 GitHub에서 호스팅되는 오픈 소스 운영 체제 커널입니다. 전체 Linux 커널 소스 코드 배포판은 매우 방대하며 여러 하위 시스템 및 모듈과 관련된 수십만 줄의 코드를 포함합니다. Linux 커널 소스 코드를 더 깊이 이해하려면

Golang 프로젝트 공개: Go 언어로 인기 있는 프로젝트 탐색 Feb 29, 2024 pm 04:09 PM

Golang 프로젝트 공개: Go 언어의 인기 프로젝트 살펴보기 효율적이고 간결하며 강력한 프로그래밍 언어인 Go 언어는 최근 몇 년간 개발자들로부터 많은 관심과 호감을 불러일으켰습니다. 많은 프로젝트 중에는 높은 성능, 동시 처리, 간결한 코드 및 기타 특성으로 인해 많은 개발자의 관심을 끄는 존경 받고 인기 있는 프로젝트가 있습니다. 이 기사에서는 독자들이 이러한 뛰어난 Go 프로젝트를 심층적으로 탐색하고 특정 코드 예제를 결합하여 그 뒤에 있는 디자인 아이디어와 엔지니어링 구현을 공개하도록 안내합니다. 1.GinGin은 사용자 친화적입니다.

See all articles