memcached探索之thread model(2)-MySQL-Tutorial-php.cn

Heim

Datenbank

MySQL-Tutorial

memcached探索之thread model(2)

WBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWB

Jun 07, 2016 pm 03:11 PM

memcached model thread unter ICH 探索

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; }

Erklärung dieser Website

Der Inhalt dieses Artikels wird freiwillig von Internetnutzern beigesteuert und das Urheberrecht liegt beim ursprünglichen Autor. Diese Website übernimmt keine entsprechende rechtliche Verantwortung. Wenn Sie Inhalte finden, bei denen der Verdacht eines Plagiats oder einer Rechtsverletzung besteht, wenden Sie sich bitte an admin@php.cn

Heiße KI -Werkzeuge

Undresser.AI Undress

KI-gestützte App zum Erstellen realistischer Aktfotos

AI Clothes Remover

Online-KI-Tool zum Entfernen von Kleidung aus Fotos.

Undress AI Tool

Ausziehbilder kostenlos

Clothoff.io

KI-Kleiderentferner

AI Hentai Generator

Erstellen Sie kostenlos Ai Hentai.

Heißer Artikel

R.E.P.O. Energiekristalle erklärten und was sie tun (gelber Kristall)

3 Wochen vor By 尊渡假赌尊渡假赌尊渡假赌

R.E.P.O. Beste grafische Einstellungen

3 Wochen vor By 尊渡假赌尊渡假赌尊渡假赌

Assassin's Creed Shadows: Seashell Riddle -Lösung

1 Wochen vor By DDD

R.E.P.O. So reparieren Sie Audio, wenn Sie niemanden hören können

3 Wochen vor By 尊渡假赌尊渡假赌尊渡假赌

WWE 2K25: Wie man alles in Myrise freischaltet

3 Wochen vor By 尊渡假赌尊渡假赌尊渡假赌

Heiße Werkzeuge

Notepad++7.3.1

Einfach zu bedienender und kostenloser Code-Editor

SublimeText3 chinesische Version

Chinesische Version, sehr einfach zu bedienen

Senden Sie Studio 13.0.1

Leistungsstarke integrierte PHP-Entwicklungsumgebung

Dreamweaver CS6

Visuelle Webentwicklungstools

SublimeText3 Mac-Version

Codebearbeitungssoftware auf Gottesniveau (SublimeText3)

Heiße Themen

Wo ist der Login-Zugang für Gmail-E-Mail?

7455

CakePHP-Tutorial

1375

Wie lautet das Format des Kontonamens von Steam?

Win11 -Aktivierungsschlüssel dauerhaft

NYT -Verbindungen Hinweise und Antworten

Related knowledge

Entdecken Sie die zukünftigen Entwicklungstrends der Go-Sprache Mar 24, 2024 pm 01:42 PM

Titel: Erkundung der zukünftigen Entwicklungstrends der Go-Sprache Mit der rasanten Entwicklung der Internettechnologie werden auch Programmiersprachen ständig weiterentwickelt und verbessert. Unter anderem ist die von Google entwickelte Open-Source-Programmiersprache Go (Golang) wegen ihrer Einfachheit, Effizienz und Parallelitätsfunktionen sehr gefragt. Da immer mehr Unternehmen und Entwickler beginnen, die Go-Sprache zum Erstellen von Anwendungen zu verwenden, hat der zukünftige Entwicklungstrend der Go-Sprache große Aufmerksamkeit erregt. 1. Eigenschaften und Vorteile der Go-Sprache Die Go-Sprache ist eine statisch typisierte Programmiersprache mit Garbage-Collection-Mechanismus und

Enthüllung der Geheimnisse der Leinwandeigenschaften Jan 17, 2024 am 10:08 AM

Um die Geheimnisse des Canvas-Attributs zu erkunden, benötigen Sie spezifische Codebeispiele. Canvas ist ein sehr leistungsfähiges Grafik-Zeichentool in HTML5. Damit können wir problemlos komplexe Grafiken, dynamische Effekte, Spiele usw. auf Webseiten zeichnen. Um es verwenden zu können, müssen wir jedoch mit den zugehörigen Eigenschaften und Methoden von Canvas vertraut sein und deren Verwendung beherrschen. In diesem Artikel werden wir einige der Kerneigenschaften von Canvas untersuchen und spezifische Codebeispiele bereitstellen, um den Lesern zu helfen, besser zu verstehen, wie diese Eigenschaften verwendet werden sollten.

Trezor Cold Wallet: Funktions- und Nutzungshandbuch für Model One und Model T Jan 19, 2024 pm 04:12 PM

Nachdem an vielen zentralisierten Börsen Probleme aufgetreten waren, begannen immer mehr Kryptowährungsinvestoren, Vermögenswerte auf Cold Wallets zu übertragen, um die von zentralisierten Börsen ausgehenden Risiken zu verringern. In diesem Artikel wird Trezor vorgestellt, der weltweit erste Cold Wallet-Anbieter. Seit der Einführung des ersten Cold Wallets im Jahr 2014 wurde es in vielen Ländern auf der ganzen Welt verkauft. Zu den Produkten von Trezor gehören das 2014 eingeführte Model One und die 2018 eingeführte Weiterentwicklung des Model T. Im Folgenden werden weiterhin die Unterschiede zwischen diesen beiden Produkten und anderen Cold Wallets vorgestellt. Was ist Trezor Cold Wallet? Im Jahr 2014 brachte Trezor das erste Cold Wallet ModelOne auf den Markt. Neben gängigen BTC, ETH, USDT und anderen Währungen unterstützt das Wallet auch mehr als 1.000 weitere Währungen.

Erkundung häufig verwendeter Datenbankauswahlen in der Go-Sprache Jan 28, 2024 am 08:04 AM

Entdecken Sie häufig verwendete Datenbankauswahlen in der Go-Sprache. Einführung: In der modernen Softwareentwicklung, egal ob es sich um Webanwendungen, mobile Anwendungen oder Internet-of-Things-Anwendungen handelt, sind Datenspeicherung und Abfrage untrennbar miteinander verbunden. In der Go-Sprache verfügen wir über viele hervorragende Datenbankoptionen. In diesem Artikel werden häufig verwendete Datenbankoptionen in der Go-Sprache untersucht und spezifische Codebeispiele bereitgestellt, um den Lesern das Verständnis und die Auswahl einer Datenbank zu erleichtern, die ihren Anforderungen entspricht. 1. SQL-Datenbank MySQL MySQL ist ein beliebtes relationales Open-Source-Datenbankverwaltungssystem. Es unterstützt eine Vielzahl von Funktionen und

Ich werde mit einem Rucksack nach Tibet reisen. ① Wie viele Liter Gepäck kann ich zum ersten Mal mitnehmen? Jan 07, 2024 am 10:06 AM

Ich plane eine Rucksacktour in Tibet. ① Sagen Sie mir bitte, was die beste Konfiguration ist. Ich bin 170 und habe eine gute körperliche Stärke Liter oder mehr. Die gesamte Reise dauerte nicht mit dem Auto, ein Koffer ist praktischer, wenn man etwas mitnehmen muss Tasche ist mehr als genug. Notwendige Utensilien für Reisen nach Tibet: Sonnenbrille, Sonnenhut, Sonnencreme, Hautcreme, langärmelige Oberteile, Pullover für besondere Reisen oder Reisen nach Ali, Nordtibet und zur Sichuan-Tibet-Linie Es wird empfohlen, Folgendes mitzubringen: Schlafsack (Kälteschutz), Laken (Schmutzschutz), Daunenjacke, Reise- oder Wanderschuhe, Hausschuhe, Zahnbürste, Zahnpasta, Handtuch, Zigarettenpapier, Papierunterwäsche, Desinfektionstücher, Taschenlampe, wasserfeste Streichhölzer, Messer , Seil. Kann ein Computer in der Vordertasche transportiert werden? Kann ein Computer in der Vordertasche transportiert werden?

Erkunden der Graphprogrammierung in Go: Möglichkeiten der Implementierung von Graph-APIs Mar 25, 2024 am 11:03 AM

Erforschung der Grafikprogrammierung in der Go-Sprache: die Möglichkeit der Implementierung von Grafik-APIs Mit der kontinuierlichen Weiterentwicklung der Computertechnologie ist die Grafikprogrammierung zu einem wichtigen Anwendungsgebiet in der Informatik geworden. Durch Grafikprogrammierung können wir verschiedene exquisite grafische Schnittstellen, Animationseffekte und Datenvisualisierungen realisieren und den Benutzern ein intuitiveres und benutzerfreundlicheres interaktives Erlebnis bieten. Mit der rasanten Entwicklung der Go-Sprache in den letzten Jahren haben immer mehr Entwickler begonnen, ihre Aufmerksamkeit auf die Anwendung der Go-Sprache im Bereich der Grafikprogrammierung zu richten. In diesem Artikel befassen wir uns mit der Implementierung

Eine ausführliche Untersuchung der Verteilung des Linux-Kernel-Quellcodes Mar 15, 2024 am 10:21 AM

Dies ist ein Artikel mit 1500 Wörtern, der die Verteilung des Linux-Kernel-Quellcodes eingehend untersucht. Aufgrund des begrenzten Platzes konzentrieren wir uns auf die Organisationsstruktur des Linux-Kernel-Quellcodes und stellen einige spezifische Codebeispiele bereit, um den Lesern ein besseres Verständnis zu ermöglichen. Der Linux-Kernel ist ein Open-Source-Betriebssystemkernel, dessen Quellcode auf GitHub gehostet wird. Die gesamte Quellcodeverteilung des Linux-Kernels ist sehr umfangreich und enthält Hunderttausende Codezeilen, die mehrere verschiedene Subsysteme und Module umfassen. Um ein tieferes Verständnis des Linux-Kernel-Quellcodes zu erlangen

Golang-Projekt enthüllt: Entdecken Sie beliebte Projekte in der Go-Sprache Feb 29, 2024 pm 04:09 PM

Golang-Projekt enthüllt: Entdecken Sie beliebte Projekte der Go-Sprache. Als effiziente, prägnante und leistungsstarke Programmiersprache hat die Go-Sprache in den letzten Jahren viel Aufmerksamkeit und Gunst bei Entwicklern auf sich gezogen. Unter vielen Projekten gibt es einige angesehene und beliebte Projekte, die aufgrund ihrer hohen Leistung, gleichzeitigen Verarbeitung, ihres prägnanten Codes und anderer Merkmale zum Fokus der Anziehungskraft einer großen Anzahl von Entwicklern geworden sind. Dieser Artikel führt die Leser dazu, diese hervorragenden Go-Projekte eingehend zu erkunden und spezifische Codebeispiele zu kombinieren, um die Designideen und technischen Implementierungen dahinter aufzuzeigen. 1.GinGin ist benutzerfreundlich

See all articles