mirror of
https://github.com/postgres/postgres.git
synced 2025-06-14 18:42:34 +03:00
da5aeccf64
We had two copies of this function in the backend and libpq, which was already pretty bogus, but it turns out that we need it in some other programs that don't use libpq (such as pg_test_fsync). So put it where it probably should have been all along. The signal-mask-initialization support in src/backend/libpq/pqsignal.c stays where it is, though, since we only need that in the backend.
122 lines
3.1 KiB
C
122 lines
3.1 KiB
C
/*-------------------------------------------------------------------------
|
|
*
|
|
* timer.c
|
|
* Microsoft Windows Win32 Timer Implementation
|
|
*
|
|
* Limitations of this implementation:
|
|
*
|
|
* - Does not support interval timer (value->it_interval)
|
|
* - Only supports ITIMER_REAL
|
|
*
|
|
* Portions Copyright (c) 1996-2013, PostgreSQL Global Development Group
|
|
*
|
|
* IDENTIFICATION
|
|
* src/backend/port/win32/timer.c
|
|
*
|
|
*-------------------------------------------------------------------------
|
|
*/
|
|
|
|
#include "postgres.h"
|
|
|
|
|
|
/* Communication area for inter-thread communication */
|
|
typedef struct timerCA
|
|
{
|
|
struct itimerval value;
|
|
HANDLE event;
|
|
CRITICAL_SECTION crit_sec;
|
|
} timerCA;
|
|
|
|
static timerCA timerCommArea;
|
|
static HANDLE timerThreadHandle = INVALID_HANDLE_VALUE;
|
|
|
|
|
|
/* Timer management thread */
|
|
static DWORD WINAPI
|
|
pg_timer_thread(LPVOID param)
|
|
{
|
|
DWORD waittime;
|
|
|
|
Assert(param == NULL);
|
|
|
|
waittime = INFINITE;
|
|
|
|
for (;;)
|
|
{
|
|
int r;
|
|
|
|
r = WaitForSingleObjectEx(timerCommArea.event, waittime, FALSE);
|
|
if (r == WAIT_OBJECT_0)
|
|
{
|
|
/* Event signalled from main thread, change the timer */
|
|
EnterCriticalSection(&timerCommArea.crit_sec);
|
|
if (timerCommArea.value.it_value.tv_sec == 0 &&
|
|
timerCommArea.value.it_value.tv_usec == 0)
|
|
waittime = INFINITE; /* Cancel the interrupt */
|
|
else
|
|
{
|
|
/* WaitForSingleObjectEx() uses milliseconds, round up */
|
|
waittime = (timerCommArea.value.it_value.tv_usec + 999) / 1000 +
|
|
timerCommArea.value.it_value.tv_sec * 1000;
|
|
}
|
|
ResetEvent(timerCommArea.event);
|
|
LeaveCriticalSection(&timerCommArea.crit_sec);
|
|
}
|
|
else if (r == WAIT_TIMEOUT)
|
|
{
|
|
/* Timeout expired, signal SIGALRM and turn it off */
|
|
pg_queue_signal(SIGALRM);
|
|
waittime = INFINITE;
|
|
}
|
|
else
|
|
{
|
|
/* Should never happen */
|
|
Assert(false);
|
|
}
|
|
}
|
|
|
|
return 0;
|
|
}
|
|
|
|
/*
|
|
* Win32 setitimer emulation by creating a persistent thread
|
|
* to handle the timer setting and notification upon timeout.
|
|
*/
|
|
int
|
|
setitimer(int which, const struct itimerval * value, struct itimerval * ovalue)
|
|
{
|
|
Assert(value != NULL);
|
|
Assert(value->it_interval.tv_sec == 0 && value->it_interval.tv_usec == 0);
|
|
Assert(which == ITIMER_REAL);
|
|
|
|
if (timerThreadHandle == INVALID_HANDLE_VALUE)
|
|
{
|
|
/* First call in this backend, create event and the timer thread */
|
|
timerCommArea.event = CreateEvent(NULL, TRUE, FALSE, NULL);
|
|
if (timerCommArea.event == NULL)
|
|
ereport(FATAL,
|
|
(errmsg_internal("could not create timer event: error code %lu",
|
|
GetLastError())));
|
|
|
|
MemSet(&timerCommArea.value, 0, sizeof(struct itimerval));
|
|
|
|
InitializeCriticalSection(&timerCommArea.crit_sec);
|
|
|
|
timerThreadHandle = CreateThread(NULL, 0, pg_timer_thread, NULL, 0, NULL);
|
|
if (timerThreadHandle == INVALID_HANDLE_VALUE)
|
|
ereport(FATAL,
|
|
(errmsg_internal("could not create timer thread: error code %lu",
|
|
GetLastError())));
|
|
}
|
|
|
|
/* Request the timer thread to change settings */
|
|
EnterCriticalSection(&timerCommArea.crit_sec);
|
|
if (ovalue)
|
|
*ovalue = timerCommArea.value;
|
|
timerCommArea.value = *value;
|
|
LeaveCriticalSection(&timerCommArea.crit_sec);
|
|
SetEvent(timerCommArea.event);
|
|
|
|
return 0;
|
|
}
|