天天看點

對pgpool-II的child process的了解

如果debug 狀态下運作 pgpool-II, 會發現它生成了很多的子程序。

這些子程序是如何生成和利用的?

看源代碼中的作法:

pgpool.conf 配置檔案中有如下選項:num_init_children

在main.c程式中,有如下的代碼部分(去掉了一部分無關代碼):

複制代碼

/*                    

* pgpool main program                    

*/                    

int main(int argc, char **argv)                    

{                    

    ……                

    /* fork the children */                

    for (i=0;i<pool_config->num_init_children;i++)                

    {                

        process_info[i].pid = fork_a_child(unix_fd, inet_fd, i);            

        process_info[i].start_time = time(NULL);            

    }                

    /* set up signal handlers */  

    pool_signal(SIGTERM, exit_handler);                

    pool_signal(SIGINT, exit_handler);                

    pool_signal(SIGQUIT, exit_handler);                

    pool_signal(SIGCHLD, reap_handler);                

    pool_signal(SIGUSR1, failover_handler);                

    pool_signal(SIGUSR2, wakeup_handler);                

    pool_signal(SIGHUP, reload_config_handler);                

    /* create pipe for delivering event */                

    if (pipe(pipe_fds) < 0)                

        pool_error("failed to create pipe");            

        myexit(1);            

    pool_log("%s successfully started. version %s (%s)", 

        PACKAGE, VERSION, PGPOOLVERSION);

    /*                

     * This is the main loop                

     */                

    for (;;)                

        ……            

    }              

    pool_shmem_exit(0);                

}

也就是說,有多少個num_init_children, 就要fork()多少次。

再看具體的 fork_a_child 函數:

* fork a child                    

pid_t fork_a_child(int unix_fd, int inet_fd, int id)                    

    pid_t pid;                

    pid = fork();                

    if (pid == 0)                

        ……         

        /* call child main */            

        POOL_SETMASK(&UnBlockSig);            

        reload_config_request = 0;            

        my_proc_id = id;            

        run_as_pcp_child = false;            

        do_child(unix_fd, inet_fd);            

    else if (pid == -1)                

        pool_error("fork() failed. reason: %s", strerror(errno));            

    return pid;                

}                    

從上面可以看出來,每fork一個程序,就會執行 do_child函數,也就是說各個子程序就開始工作工作了。

do_child函數的具體内容如下:

* child main loop                    

void do_child(int unix_fd, int inet_fd)                    

{                

        /* perform accept() */            

        frontend = do_accept(unix_fd, inet_fd, &timeout);            

        if (frontend == NULL)/* connection request from frontend timed out */

        {            

            ……        

        }  

        ……          

        /* query process loop */            

        for (;;)            

        }            

    child_exit(0);                

do_child函數裡面調用 do_accept函數,如果用戶端有請求近來,就會開始響應用戶端,開始工作。

本文轉自健哥的資料花園部落格園部落格,原文連結:http://www.cnblogs.com/gaojian/archive/2012/07/30/2615106.html,如需轉載請自行聯系原作者