PostgreSQL在Windows系统下的信号处理

原创
2019/08/22 10:37
阅读数 195

本篇大致捋一下PostgreSQL在Windows下的信号处理,其实只能说是模拟或者代码封装,调用的时候看起来也是 pgsignal 函数,实现了代码的跨平台,但在实现上完全跟信号无关,毕竟Windows也没有这个特性。

1、PostgreSQL的Windows代码在函数 save_backend_variables 中:

#ifdef WIN32
  param->PostmasterHandle = PostmasterHandle;
  if (!write_duplicated_handle(&param->initial_signal_pipe,
                 pgwin32_create_signal_listener(childPid),
                 childProcess))
    return false;
#else

下边分别讲这里的两个函数,用到的API可以自行查阅微软文档。

2、创建命名管道

函数 pgwin32_create_signal_listener 的作用是创建一个命名管道

  snprintf(pipename, sizeof(pipename), "\\\\.\\pipe\\pgsignal_%u", (int) pid);

  pipe = CreateNamedPipe(pipename, PIPE_ACCESS_DUPLEX,
               PIPE_TYPE_MESSAGE | PIPE_READMODE_MESSAGE | PIPE_WAIT,
               PIPE_UNLIMITED_INSTANCES, 16, 16, 1000, NULL);

3、复制管道句柄

函数 write_duplicated_handle 中:

  if (!DuplicateHandle(GetCurrentProcess(),
             src,
             childProcess,
             &hChild,
             0,
             TRUE,
             DUPLICATE_CLOSE_SOURCE | DUPLICATE_SAME_ACCESS))

这个复制的句柄通过 param 传递给新创建的后端进程。

4、Windows下的信号函数

pqsigfunc
pqsignal(int signum, pqsigfunc handler)
{
  pqsigfunc  prevfunc;

  if (signum >= PG_SIGNAL_COUNT || signum < 0)
    return SIG_ERR;
  prevfunc = pg_signal_array[signum];
  pg_signal_array[signum] = handler;
  return prevfunc;
}

这里有一个信号处理函数数组,pqsignal 的作用是记录下这是处理哪个信号的函数。

5、Windows下的 kill 函数

#define kill(pid,sig)  pgkill(pid,sig)
extern int  pgkill(int pid, int sig);

pgkill 里,使用上边创建的命名管道

  snprintf(pipename, sizeof(pipename), "\\\\.\\pipe\\pgsignal_%u", pid);
  if (CallNamedPipe(pipename, &sigData, 1, &sigRet, 1, &bytes, 1000))

将信号写入管道,例如 SIGHUP。

6、信号处理线程

在启动时,创建一个专门处理命名管道事件的线程:

  /* Create thread for handling signals */
  signal_thread_handle = CreateThread(NULL, 0, pg_signal_thread, NULL, 0, NULL);

7、后端进程的信号处理

函数 pg_signal_dispatch_thread 里(src/backend/port/win32/signal.c):

  /* Create thread for handling signals */
  signal_thread_handle = CreateThread(NULL, 0, pg_signal_thread, NULL, 0, NULL);
...
  pg_queue_signal(sigNum);

欢迎关注公众号

展开阅读全文
打赏
0
0 收藏
分享
加载中
更多评论
打赏
0 评论
0 收藏
0
分享
返回顶部
顶部