PostgreSQLserver端接收連接后fork進(jìn)程

main->PostmasterMain->ServerLoop:
	for(;;){
		...
		//會阻塞在這,監(jiān)視文件描述符的變化
		selres = select(nSockets, &rmask, NULL, NULL, &timeout);
		if (selres > 0){
			for (i = 0; i < MAXLISTEN; i++){
				//找一個(gè)有效的fd
				if (ListenSocket[i] == PGINVALID_SOCKET)
					break;
				if (FD_ISSET(ListenSocket[i], &rmask)){
					port = ConnCreate(ListenSocket[i]);->StreamConnection->accept
					BackendStartup(port);//fork進(jìn)程
					|--	pid = fork_process();
					|	if (pid == 0){//child
					|		InitPostmasterChild();
					|		ClosePostmasterPorts(false);
					|		BackendInitialize(port);
					|		//該函數(shù)不會返回
					|		BackendRun(port);->PostgresMain:
					|		|--	for (;;){
					|		|		if (send_ready_for_query){
					|		|			...
					|		|			ReadyForQuery(whereToSendOutput);->pq_flush();->internal_flush->secure_write->secure_raw_write->send
					|		|			send_ready_for_query = false;
					|		|		}
					|		|		firstchar = ReadCommand(&input_message);
					|		|		switch(firstchar):{
					|		|			case 'Q':exec_simple_query(query_string);
					|		|			...
					|		|		}
					|		|--	}
					|	}
					|	...father
					|--	return STATUS_OK	
					//關(guān)閉father socket
					StreamClose(port->sock);
					ConnFree(port);
				}
			}
		}
	}

標(biāo)題名稱:PostgreSQLserver端接收連接后fork進(jìn)程
當(dāng)前路徑:http://muchs.cn/article38/pgoipp.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供App開發(fā)、品牌網(wǎng)站設(shè)計(jì)、、網(wǎng)站策劃網(wǎng)站制作、ChatGPT

廣告

聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時(shí)需注明來源: 創(chuàng)新互聯(lián)

小程序開發(fā)