对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));

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，如需转载请自行联系原作者