且构网

分享程序员开发的那些事...
且构网 - 分享程序员编程开发的那些事

对pgpool-II的child process的理解

更新时间:2022-09-18 22:42:06

如果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));            
        myexit(1);            
    }                
    return pid;                
}                    
复制代码
从上面可以看出来,每fork一个进程,就会执行 do_child函数,也就是说各个子进程就开始工作工作了。

do_child函数的具体内容如下:

复制代码
/*                    
* child main loop                    
*/                    
void do_child(int unix_fd, int inet_fd)                    
{                
    ……                
                    
    for (;;)                
    {                
        ……            
        /* 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,如需转载请自行联系原作者