#include <winsock2.h>
#include <ws2tcpip.h>
#include <windows.h>
#include <process.h>
#include <signal.h>
#include <direct.h>
#include <sys/stat.h>

Include dependency graph for win32_port.h:

Go to the source code of this file.

Data Structures
struct	timezone

struct	itimerval

Macros
#define	ENABLE_SSPI 1

#define	_WINSOCKAPI_

#define	mkdir(a, b) mkdir(a)

#define	ftruncate(a, b) chsize(a,b)

#define	fsync(fd) _commit(fd)

#define	HAVE_FSYNC_WRITETHROUGH

#define	FSYNC_WRITETHROUGH_IS_FSYNC

#define	USES_WINSOCK

#define	HAVE_UNION_SEMUN 1

#define	IPC_RMID 256

#define	IPC_CREAT 512

#define	IPC_EXCL 1024

#define	IPC_PRIVATE 234564

#define	IPC_NOWAIT 2048

#define	IPC_STAT 4096

#define	EACCESS 2048

#define	EIDRM 4096

#define	SETALL 8192

#define	GETNCNT 16384

#define	GETVAL 65536

#define	SETVAL 131072

#define	GETPID 262144

#define	WIFEXITED(w) (((w) & 0XFFFFFF00) == 0)

#define	WIFSIGNALED(w) (!WIFEXITED(w))

#define	WEXITSTATUS(w) (w)

#define	WTERMSIG(w) (w)

#define	sigmask(sig) ( 1 << ((sig)-1) )

#define	SIG_DFL ((pqsigfunc)0)

#define	SIG_ERR ((pqsigfunc)-1)

#define	SIG_IGN ((pqsigfunc)1)

#define	SIGHUP 1

#define	SIGQUIT 3

#define	SIGTRAP 5

#define	SIGABRT 22 /* Set to match W32 value -- not UNIX value */

#define	SIGKILL 9

#define	SIGPIPE 13

#define	SIGALRM 14

#define	SIGSTOP 17

#define	SIGTSTP 18

#define	SIGCONT 19

#define	SIGCHLD 20

#define	SIGWINCH 28

#define	SIGUSR1 30

#define	SIGUSR2 31

#define	ITIMER_REAL 0

#define	pgoff_t __int64

#define	fseeko(stream, offset, origin) fseeko64(stream, offset, origin)

#define	ftello(stream) ftello64(stream)

#define	symlink(oldpath, newpath) pgsymlink(oldpath, newpath)

#define	readlink(path, buf, size) pgreadlink(path, buf, size)

#define	lstat(path, sb) stat(path, sb)

#define	stat(a, b) pgwin32_safestat(a,b)

#define	S_IRUSR _S_IREAD

#define	S_IWUSR _S_IWRITE

#define	S_IXUSR _S_IEXEC

#define	S_IRWXU (S_IRUSR \| S_IWUSR \| S_IXUSR)

#define	S_IRGRP 0

#define	S_IWGRP 0

#define	S_IXGRP 0

#define	S_IRWXG 0

#define	S_IROTH 0

#define	S_IWOTH 0

#define	S_IXOTH 0

#define	S_IRWXO 0

#define	S_ISDIR(m) (((m) & S_IFMT) == S_IFDIR)

#define	S_ISREG(m) (((m) & S_IFMT) == S_IFREG)

#define	O_DSYNC 0x0080

#define	EAGAIN WSAEWOULDBLOCK

#define	EINTR WSAEINTR

#define	EMSGSIZE WSAEMSGSIZE

#define	EAFNOSUPPORT WSAEAFNOSUPPORT

#define	EWOULDBLOCK WSAEWOULDBLOCK

#define	ECONNABORTED WSAECONNABORTED

#define	ECONNRESET WSAECONNRESET

#define	EINPROGRESS WSAEINPROGRESS

#define	EISCONN WSAEISCONN

#define	ENOBUFS WSAENOBUFS

#define	EPROTONOSUPPORT WSAEPROTONOSUPPORT

#define	ECONNREFUSED WSAECONNREFUSED

#define	ENOTSOCK WSAENOTSOCK

#define	EOPNOTSUPP WSAEOPNOTSUPP

#define	EADDRINUSE WSAEADDRINUSE

#define	EADDRNOTAVAIL WSAEADDRNOTAVAIL

#define	EHOSTUNREACH WSAEHOSTUNREACH

#define	ENOTCONN WSAENOTCONN

#define	locale_t _locale_t

#define	tolower_l _tolower_l

#define	toupper_l _toupper_l

#define	towlower_l _towlower_l

#define	towupper_l _towupper_l

#define	isdigit_l _isdigit_l

#define	iswdigit_l _iswdigit_l

#define	isalpha_l _isalpha_l

#define	iswalpha_l _iswalpha_l

#define	isalnum_l _isalnum_l

#define	iswalnum_l _iswalnum_l

#define	isupper_l _isupper_l

#define	iswupper_l _iswupper_l

#define	islower_l _islower_l

#define	iswlower_l _iswlower_l

#define	isgraph_l _isgraph_l

#define	iswgraph_l _iswgraph_l

#define	isprint_l _isprint_l

#define	iswprint_l _iswprint_l

#define	ispunct_l _ispunct_l

#define	iswpunct_l _iswpunct_l

#define	isspace_l _isspace_l

#define	iswspace_l _iswspace_l

#define	strcoll_l _strcoll_l

#define	strxfrm_l _strxfrm_l

#define	wcscoll_l _wcscoll_l

#define	wcstombs_l _wcstombs_l

#define	mbstowcs_l _mbstowcs_l

#define	setlocale(a, b) pgwin32_setlocale(a,b)

#define	UNBLOCKED_SIGNAL_QUEUE() (pg_signal_queue & ~pg_signal_mask)

#define	PG_SIGNAL_COUNT 32

#define	kill(pid, sig) pgkill(pid,sig)

#define	socket(af, type, protocol) pgwin32_socket(af, type, protocol)

#define	bind(s, addr, addrlen) pgwin32_bind(s, addr, addrlen)

#define	listen(s, backlog) pgwin32_listen(s, backlog)

#define	accept(s, addr, addrlen) pgwin32_accept(s, addr, addrlen)

#define	connect(s, name, namelen) pgwin32_connect(s, name, namelen)

#define	select(n, r, w, e, timeout) pgwin32_select(n, r, w, e, timeout)

#define	recv(s, buf, len, flags) pgwin32_recv(s, buf, len, flags)

#define	send(s, buf, len, flags) pgwin32_send(s, buf, len, flags)

#define	putenv(x) pgwin32_putenv(x)

#define	unsetenv(x) pgwin32_unsetenv(x)

Typedefs
typedef int	uid_t

typedef int	gid_t

typedef long	key_t

Functions
int	setitimer (int which, const struct itimerval value, struct itimerval ovalue)

int	pgsymlink (const char oldpath, const char newpath)

int	pgreadlink (const char path, char buf, size_t size)

bool	pgwin32_is_junction (const char *path)

int	pgwin32_safestat (const char path, struct stat buf)

char *	pgwin32_setlocale (int category, const char *locale)

void	pgwin32_signal_initialize (void)

HANDLE	pgwin32_create_signal_listener (pid_t pid)

void	pgwin32_dispatch_queued_signals (void)

void	pg_queue_signal (int signum)

int	pgkill (int pid, int sig)

SOCKET	pgwin32_socket (int af, int type, int protocol)

int	pgwin32_bind (SOCKET s, struct sockaddr *addr, int addrlen)

int	pgwin32_listen (SOCKET s, int backlog)

SOCKET	pgwin32_accept (SOCKET s, struct sockaddr addr, int addrlen)

int	pgwin32_connect (SOCKET s, const struct sockaddr *name, int namelen)

int	pgwin32_select (int nfds, fd_set readfds, fd_set writefds, fd_set exceptfds, const struct timeval timeout)

int	pgwin32_recv (SOCKET s, char *buf, int len, int flags)

int	pgwin32_send (SOCKET s, const void *buf, int len, int flags)

int	pgwin32_waitforsinglesocket (SOCKET s, int what, int timeout)

int	pgwin32_ReserveSharedMemoryRegion (HANDLE)

void	pgwin32_install_crashdump_handler (void)

void	_dosmaperr (unsigned long)

int	pgwin32_putenv (const char *)

void	pgwin32_unsetenv (const char *)

int	pgwin32_is_service (void)

int	pgwin32_is_admin (void)

BOOL	AddUserToTokenDacl (HANDLE hToken)

Variables
PGDLLIMPORT volatile int	pg_signal_queue

PGDLLIMPORT int	pg_signal_mask

HANDLE	pgwin32_signal_event

HANDLE	pgwin32_initial_signal_pipe

int	pgwin32_noblock

Macro Definition Documentation

◆ _WINSOCKAPI_

#define _WINSOCKAPI_

Definition at line 43 of file win32_port.h.

◆ accept

#define accept	(	s,
		addr,
		addrlen
	)	pgwin32_accept(s, addr, addrlen)

Definition at line 434 of file win32_port.h.

Referenced by readMessageFromPipe(), and StreamConnection().

◆ bind

#define bind	(	s,
		addr,
		addrlen
	)	pgwin32_bind(s, addr, addrlen)

Definition at line 432 of file win32_port.h.

Referenced by ident_inet(), PerformRadiusTransaction(), pgstat_init(), pgwin32_bind(), readMessageFromPipe(), and StreamServerPort().

◆ connect

#define connect	(	s,
		name,
		namelen
	)	pgwin32_connect(s, name, namelen)

Definition at line 435 of file win32_port.h.

Referenced by CreateSubscription(), ident_inet(), internal_cancel(), parse_subscription_options(), pgstat_init(), PQconnectPoll(), and readMessageFromPipe().

◆ EACCESS

#define EACCESS 2048

Definition at line 87 of file win32_port.h.

◆ EADDRINUSE

#define EADDRINUSE WSAEADDRINUSE

Definition at line 349 of file win32_port.h.

Referenced by get_errno_symbol(), and TranslateSocketError().

◆ EADDRNOTAVAIL

#define EADDRNOTAVAIL WSAEADDRNOTAVAIL

Definition at line 351 of file win32_port.h.

Referenced by get_errno_symbol(), and TranslateSocketError().

◆ EAFNOSUPPORT

#define EAFNOSUPPORT WSAEAFNOSUPPORT

Definition at line 327 of file win32_port.h.

Referenced by get_errno_symbol(), pg_inet_cidr_ntop(), pg_inet_net_ntop(), pg_inet_net_pton(), and TranslateSocketError().

◆ EAGAIN

#define EAGAIN WSAEWOULDBLOCK

◆ ECONNABORTED

#define ECONNABORTED WSAECONNABORTED

Definition at line 331 of file win32_port.h.

Referenced by get_errno_symbol(), and TranslateSocketError().

◆ ECONNREFUSED

#define ECONNREFUSED WSAECONNREFUSED

Definition at line 343 of file win32_port.h.

Referenced by get_errno_symbol(), and TranslateSocketError().

◆ ECONNRESET

#define ECONNRESET WSAECONNRESET

Definition at line 333 of file win32_port.h.

Referenced by be_tls_read(), be_tls_write(), errcode_for_socket_access(), get_errno_symbol(), pgtls_read(), pgtls_write(), pqReadData(), pqsecure_raw_read(), pqsecure_raw_write(), and TranslateSocketError().

◆ EHOSTUNREACH

#define EHOSTUNREACH WSAEHOSTUNREACH

Definition at line 353 of file win32_port.h.

Referenced by get_errno_symbol(), and TranslateSocketError().

◆ EIDRM

#define EIDRM 4096

Definition at line 89 of file win32_port.h.

Referenced by get_errno_symbol(), InternalIpcMemoryCreate(), InternalIpcSemaphoreCreate(), and PGSharedMemoryAttach().

◆ EINPROGRESS

#define EINPROGRESS WSAEINPROGRESS

Definition at line 335 of file win32_port.h.

Referenced by get_errno_symbol(), PQconnectPoll(), and TranslateSocketError().

◆ EINTR

#define EINTR WSAEINTR

Definition at line 323 of file win32_port.h.

Referenced by CopyStreamPoll(), drainSelfPipe(), dsm_impl_op(), FileRead(), FileWrite(), get_errno_symbol(), gss_read(), ident_inet(), internal_cancel(), internal_flush(), my_sock_read(), my_sock_write(), PerformRadiusTransaction(), pg_usleep(), PGSemaphoreLock(), PGSemaphoreReset(), PGSemaphoreTryLock(), PGSemaphoreUnlock(), pgstat_init(), pgstat_send(), PgstatCollectorMain(), pgwin32_poll_signals(), pgwin32_select(), pgwin32_waitforsinglesocket(), pq_getbyte_if_available(), pq_recvbuf(), PQconnectPoll(), pqReadData(), pqsecure_open_gss(), pqsecure_raw_read(), pqsecure_raw_write(), pqSendSome(), pqSocketCheck(), ProcessStartupPacket(), read_or_wait(), report_fork_failure_to_client(), secure_open_gssapi(), select_loop(), sendSelfPipeByte(), ServerLoop(), StreamLogicalLog(), SysLoggerMain(), threadRun(), TranslateSocketError(), try_complete_step(), WaitEventSetWait(), and XLogWrite().

◆ EISCONN

#define EISCONN WSAEISCONN

Definition at line 337 of file win32_port.h.

Referenced by get_errno_symbol(), and TranslateSocketError().

◆ EMSGSIZE

#define EMSGSIZE WSAEMSGSIZE

Definition at line 325 of file win32_port.h.

Referenced by get_errno_symbol(), inet_cidr_ntop_ipv4(), inet_cidr_ntop_ipv6(), inet_cidr_pton_ipv4(), inet_cidr_pton_ipv6(), inet_net_ntop_ipv4(), inet_net_ntop_ipv6(), inet_net_pton_ipv4(), and TranslateSocketError().

◆ ENABLE_SSPI

#define ENABLE_SSPI 1

Definition at line 23 of file win32_port.h.

◆ ENOBUFS

#define ENOBUFS WSAENOBUFS

Definition at line 339 of file win32_port.h.

Referenced by get_errno_symbol(), and TranslateSocketError().

◆ ENOTCONN

#define ENOTCONN WSAENOTCONN

Definition at line 355 of file win32_port.h.

Referenced by get_errno_symbol(), and TranslateSocketError().

◆ ENOTSOCK

#define ENOTSOCK WSAENOTSOCK

Definition at line 345 of file win32_port.h.

Referenced by get_errno_symbol(), and TranslateSocketError().

◆ EOPNOTSUPP

#define EOPNOTSUPP WSAEOPNOTSUPP

Definition at line 347 of file win32_port.h.

Referenced by get_errno_symbol(), and TranslateSocketError().

◆ EPROTONOSUPPORT

#define EPROTONOSUPPORT WSAEPROTONOSUPPORT

Definition at line 341 of file win32_port.h.

Referenced by get_errno_symbol(), and TranslateSocketError().

◆ EWOULDBLOCK

#define EWOULDBLOCK WSAEWOULDBLOCK

◆ fseeko

#define fseeko	(	stream,
		offset,
		origin
	)	fseeko64(stream, offset, origin)

Definition at line 201 of file win32_port.h.

Referenced by _CloseArchive(), _discoverArchiveFormat(), _PrepParallelRestore(), _PrintTocData(), _ReopenArchive(), _skipData(), _tarAddFile(), checkSeek(), and read_binary_file().

◆ fsync

#define fsync ( fd ) _commit(fd)

Definition at line 62 of file win32_port.h.

Referenced by dir_sync(), OutputFsync(), pg_fdatasync(), pg_fsync_no_writethrough(), tar_finish(), tar_sync(), test_file_descriptor_sync(), test_open(), test_sync(), update_controlfile(), and WriteEmptyXLOG().

◆ FSYNC_WRITETHROUGH_IS_FSYNC

#define FSYNC_WRITETHROUGH_IS_FSYNC

Definition at line 70 of file win32_port.h.

◆ ftello

#define ftello ( stream ) ftello64(stream)

Definition at line 204 of file win32_port.h.

Referenced by _CloseArchive(), _getFilePos(), _PrepParallelRestore(), _ReopenArchive(), _tarAddFile(), _tarGetHeader(), and checkSeek().

◆ ftruncate

#define ftruncate	(	a,
		b
	)	chsize(a,b)

Definition at line 59 of file win32_port.h.

Referenced by CheckForExternalTrigger(), dsm_impl_op(), entry_reset(), FileTruncate(), gc_qtexts(), heap_xlog_logical_rewrite(), mdunlinkfork(), tar_close(), and truncate_target_file().

◆ GETNCNT

#define GETNCNT 16384

Definition at line 93 of file win32_port.h.

◆ GETPID

#define GETPID 262144

Definition at line 96 of file win32_port.h.

Referenced by IpcSemaphoreGetLastPID().

◆ GETVAL

#define GETVAL 65536

Definition at line 94 of file win32_port.h.

Referenced by IpcSemaphoreGetValue().

◆ HAVE_FSYNC_WRITETHROUGH

#define HAVE_FSYNC_WRITETHROUGH

Definition at line 69 of file win32_port.h.

◆ HAVE_UNION_SEMUN

#define HAVE_UNION_SEMUN 1

Definition at line 78 of file win32_port.h.

◆ IPC_CREAT

#define IPC_CREAT 512

Definition at line 81 of file win32_port.h.

Referenced by dsm_impl_sysv(), InternalIpcMemoryCreate(), and InternalIpcSemaphoreCreate().

◆ IPC_EXCL

#define IPC_EXCL 1024

Definition at line 82 of file win32_port.h.

Referenced by dsm_impl_sysv(), InternalIpcMemoryCreate(), and InternalIpcSemaphoreCreate().

◆ IPC_NOWAIT

#define IPC_NOWAIT 2048

Definition at line 84 of file win32_port.h.

Referenced by PGSemaphoreTryLock().

◆ IPC_PRIVATE

#define IPC_PRIVATE 234564

Definition at line 83 of file win32_port.h.

Referenced by dsm_impl_sysv().

◆ IPC_RMID

#define IPC_RMID 256

Definition at line 80 of file win32_port.h.

Referenced by dsm_impl_sysv(), InternalIpcMemoryCreate(), IpcMemoryDelete(), IpcSemaphoreCreate(), IpcSemaphoreKill(), and PGSharedMemoryCreate().

◆ IPC_STAT

#define IPC_STAT 4096

Definition at line 85 of file win32_port.h.

Referenced by dsm_impl_sysv(), and PGSharedMemoryAttach().

◆ isalnum_l

#define isalnum_l _isalnum_l

Definition at line 372 of file win32_port.h.

Referenced by pg_wc_isalnum(), and str_initcap().

◆ isalpha_l

#define isalpha_l _isalpha_l

Definition at line 370 of file win32_port.h.

Referenced by pattern_char_isalpha(), and pg_wc_isalpha().

◆ isdigit_l

#define isdigit_l _isdigit_l

Definition at line 368 of file win32_port.h.

Referenced by pg_wc_isdigit().

◆ isgraph_l

#define isgraph_l _isgraph_l

Definition at line 378 of file win32_port.h.

Referenced by pg_wc_isgraph().

◆ islower_l

#define islower_l _islower_l

Definition at line 376 of file win32_port.h.

Referenced by pg_wc_islower().

◆ isprint_l

#define isprint_l _isprint_l

Definition at line 380 of file win32_port.h.

Referenced by pg_wc_isprint().

◆ ispunct_l

#define ispunct_l _ispunct_l

Definition at line 382 of file win32_port.h.

Referenced by pg_wc_ispunct().

◆ isspace_l

#define isspace_l _isspace_l

Definition at line 384 of file win32_port.h.

Referenced by pg_wc_isspace().

◆ isupper_l

#define isupper_l _isupper_l

Definition at line 374 of file win32_port.h.

Referenced by pg_wc_isupper().

◆ iswalnum_l

#define iswalnum_l _iswalnum_l

Definition at line 373 of file win32_port.h.

Referenced by pg_wc_isalnum(), and str_initcap().

◆ iswalpha_l

#define iswalpha_l _iswalpha_l

Definition at line 371 of file win32_port.h.

Referenced by pg_wc_isalpha().

◆ iswdigit_l

#define iswdigit_l _iswdigit_l

Definition at line 369 of file win32_port.h.

Referenced by pg_wc_isdigit().

◆ iswgraph_l

#define iswgraph_l _iswgraph_l

Definition at line 379 of file win32_port.h.

Referenced by pg_wc_isgraph().

◆ iswlower_l

#define iswlower_l _iswlower_l

Definition at line 377 of file win32_port.h.

Referenced by pg_wc_islower().

◆ iswprint_l

#define iswprint_l _iswprint_l

Definition at line 381 of file win32_port.h.

Referenced by pg_wc_isprint().

◆ iswpunct_l

#define iswpunct_l _iswpunct_l

Definition at line 383 of file win32_port.h.

Referenced by pg_wc_ispunct().

◆ iswspace_l

#define iswspace_l _iswspace_l

Definition at line 385 of file win32_port.h.

Referenced by pg_wc_isspace().

◆ iswupper_l

#define iswupper_l _iswupper_l

Definition at line 375 of file win32_port.h.

Referenced by pg_wc_isupper().

◆ ITIMER_REAL

#define ITIMER_REAL 0

Definition at line 181 of file win32_port.h.

Referenced by disable_all_timeouts(), schedule_alarm(), and setitimer().

◆ kill

#define kill	(	pid,
		sig
	)	pgkill(pid,sig)

Definition at line 426 of file win32_port.h.

Referenced by ApplyLauncherWakeup(), AutoVacWorkerMain(), BackgroundWorkerStateChange(), CountOtherDBBackends(), CreateLockFile(), do_kill(), do_logrotate(), do_promote(), do_reload(), do_restart(), do_stop(), EmitProcSignalBarrier(), HandleWalSndInitStopping(), InvalidateObsoleteReplicationSlots(), IpcSemaphoreCreate(), kill_bgchild_atexit(), LockTimeoutHandler(), logicalrep_worker_stop(), maybe_start_bgworkers(), pg_promote(), pg_reload_conf(), pg_signal_backend(), pg_spinlock_barrier(), postmaster_is_alive(), ProcKill(), ProcSleep(), regression_main(), ReportBackgroundWorkerExit(), ReportBackgroundWorkerPID(), RequestCheckpoint(), SendPostmasterSignal(), SendProcSignal(), ServerLoop(), SetLatch(), ShutdownWalRcv(), ShutdownWorkersHard(), signal_child(), sigquit_handler(), sigTermHandler(), StatementTimeoutHandler(), TerminateOtherDBBackends(), trap_sigint_during_startup(), and wait_pid().

◆ listen

#define listen	(	s,
		backlog
	)	pgwin32_listen(s, backlog)

Definition at line 433 of file win32_port.h.

Referenced by pgwin32_listen(), readMessageFromPipe(), and StreamServerPort().

◆ locale_t

#define locale_t _locale_t

Definition at line 363 of file win32_port.h.

Referenced by char2wchar(), ecpg_do_epilogue(), ecpg_do_prologue(), ECPGget_desc(), pg_newlocale_from_collation(), and wchar2char().

◆ lstat

#define lstat	(	path,
		sb
	)	stat(path, sb)

◆ mbstowcs_l

#define mbstowcs_l _mbstowcs_l

Definition at line 390 of file win32_port.h.

Referenced by char2wchar().

◆ mkdir

#define mkdir	(	a,
		b
	)	mkdir(a)

Definition at line 57 of file win32_port.h.

Referenced by create_target_dir(), create_xlog_or_symlink(), GETTEMP(), InitArchiveFmt_Directory(), initialize_data_directory(), make_directory(), MakePGDirectory(), mkdirs(), pg_mkdir_p(), proc_exit(), and ReceiveTarAndUnpackCopyChunk().

◆ O_DSYNC

#define O_DSYNC 0x0080

Definition at line 308 of file win32_port.h.

Referenced by test_sync().

◆ PG_SIGNAL_COUNT

#define PG_SIGNAL_COUNT 32

Definition at line 418 of file win32_port.h.

Referenced by pg_queue_signal(), pgwin32_dispatch_queued_signals(), pgwin32_signal_initialize(), and pqsignal().

◆ pgoff_t

#define pgoff_t __int64

Definition at line 194 of file win32_port.h.

Referenced by _allocAH(), _CloseArchive(), _getFilePos(), _PrepParallelRestore(), _PrintTocData(), _ReopenArchive(), _tarAddFile(), _tarGetHeader(), _WorkerJobRestoreCustom(), checkSeek(), perform_base_backup(), ReadOffset(), sendFile(), and WriteOffset().

◆ putenv

#define putenv ( x ) pgwin32_putenv(x)

Definition at line 474 of file win32_port.h.

Referenced by CheckSCRAMAuth(), do_start(), doputenv(), ecpg_start_test(), exec_command_setenv(), get_restricted_token(), initialize_environment(), isolation_start_test(), main(), pg_perm_setlocale(), pg_putenv(), psql_start_test(), regress_putenv(), set_pglocale_pgservice(), setup_pgdata(), and unsetenv().

◆ readlink

#define readlink	(	path,
		buf,
		size
	)	pgreadlink(path, buf, size)

Definition at line 222 of file win32_port.h.

Referenced by check_system_link_file(), do_pg_start_backup(), itssymlink(), pg_tablespace_location(), recurse_dir(), resolve_symlinks(), and sendDir().

◆ recv

#define recv	(	s,
		buf,
		len,
		flags
	)	pgwin32_recv(s, buf, len, flags)

Definition at line 437 of file win32_port.h.

Referenced by ident_inet(), internal_cancel(), pgstat_init(), PgstatCollectorMain(), pqsecure_raw_read(), readMessageFromPipe(), and secure_raw_read().

◆ S_IRGRP

#define S_IRGRP 0

Definition at line 272 of file win32_port.h.

Referenced by be_lo_export(), and PostmasterMain().

◆ S_IROTH

#define S_IROTH 0

Definition at line 284 of file win32_port.h.

Referenced by be_lo_export(), and PostmasterMain().

◆ S_IRUSR

#define S_IRUSR _S_IREAD

Definition at line 260 of file win32_port.h.

Referenced by be_lo_export(), PostmasterMain(), readRecoverySignalFile(), StreamLogicalLog(), tar_open_for_write(), tarOpen(), test_open(), validate_exec(), and verify_directories().

◆ S_IRWXG

#define S_IRWXG 0

Definition at line 281 of file win32_port.h.

Referenced by check_ssl_key_file_permissions(), initialize_SSL(), logfile_open(), make_directory(), passwordFromFile(), pg_mkdir_p(), proc_exit(), and tarOpen().

◆ S_IRWXO

#define S_IRWXO 0

Definition at line 293 of file win32_port.h.

Referenced by check_ssl_key_file_permissions(), initialize_SSL(), logfile_open(), make_directory(), passwordFromFile(), pg_mkdir_p(), proc_exit(), and tarOpen().

◆ S_IRWXU

#define S_IRWXU (S_IRUSR | S_IWUSR | S_IXUSR)

Definition at line 269 of file win32_port.h.

Referenced by create_script_for_cluster_analyze(), create_script_for_old_cluster_deletion(), logfile_open(), make_directory(), pg_mkdir_p(), and proc_exit().

◆ S_ISDIR

#define S_ISDIR ( m ) (((m) & S_IFMT) == S_IFDIR)

Definition at line 296 of file win32_port.h.

Referenced by _discoverArchiveFormat(), BeginCopyFrom(), BeginCopyTo(), calculate_tablespace_size(), check_bin_dir(), check_single_dir(), checkDataDir(), copydir(), create_tablespace_directories(), createdb(), CreateSlotOnDisk(), dbase_redo(), destroy_tablespace_directories(), directory_exists(), do_copy(), file_exists(), get_dirent_type(), get_tablespace_paths(), GETTEMP(), InitArchiveFmt_Directory(), Initialize(), itsdir(), pg_file_sync(), pg_fsync(), pg_mkdir_p(), pg_stat_file(), pg_tzenumerate_next(), process_source_file(), recurse_dir(), remove_dbtablespaces(), remove_tablespace_symlink(), RemovePgTempFilesInDir(), ReorderBufferCleanupSerializedTXNs(), rmtree(), scan_available_timezones(), scan_directory(), sendDir(), StartupReplicationSlots(), TablespaceCreateDbspace(), tarCreateHeader(), ValidateXLOGDirectoryStructure(), and verify_backup_file().

◆ S_ISREG

#define S_ISREG ( m ) (((m) & S_IFMT) == S_IFREG)

◆ S_IWGRP

#define S_IWGRP 0

Definition at line 275 of file win32_port.h.

Referenced by be_lo_export(), BeginCopyTo(), check_ssl_key_file_permissions(), and main().

◆ S_IWOTH

#define S_IWOTH 0

Definition at line 287 of file win32_port.h.

Referenced by be_lo_export(), BeginCopyTo(), and main().

◆ S_IWUSR

#define S_IWUSR _S_IWRITE

Definition at line 263 of file win32_port.h.

Referenced by be_lo_export(), logfile_open(), pg_mkdir_p(), PostmasterMain(), readRecoverySignalFile(), StreamLogicalLog(), tar_open_for_write(), tarOpen(), test_open(), and verify_directories().

◆ S_IXGRP

#define S_IXGRP 0

Definition at line 278 of file win32_port.h.

Referenced by check_ssl_key_file_permissions().

◆ S_IXOTH

#define S_IXOTH 0

Definition at line 290 of file win32_port.h.

◆ S_IXUSR

#define S_IXUSR _S_IEXEC

Definition at line 266 of file win32_port.h.

Referenced by pg_mkdir_p(), and validate_exec().

◆ select

#define select	(	n,
		r,
		w,
		e,
		timeout
	)	pgwin32_select(n, r, w, e, timeout)

Definition at line 436 of file win32_port.h.

Referenced by CopyStreamPoll(), DoCopy(), getMessageFromWorker(), main(), PerformRadiusTransaction(), pg_usleep(), pgstat_init(), pqSocketPoll(), reached_end_position(), select_loop(), ServerLoop(), StreamLogicalLog(), try_complete_step(), and wait_on_socket_set().

◆ send

#define send	(	s,
		buf,
		len,
		flags
	)	pgwin32_send(s, buf, len, flags)

Definition at line 438 of file win32_port.h.

Referenced by ident_inet(), internal_cancel(), pgstat_init(), pgstat_send(), pqsecure_raw_write(), ProcessStartupPacket(), report_fork_failure_to_client(), and secure_raw_write().

◆ SETALL

#define SETALL 8192

Definition at line 92 of file win32_port.h.

◆ setlocale

#define setlocale	(	a,
		b
	)	pgwin32_setlocale(a,b)

◆ SETVAL

#define SETVAL 131072

Definition at line 95 of file win32_port.h.

Referenced by IpcSemaphoreInitialize().

◆ SIG_DFL

◆ SIG_ERR

#define SIG_ERR ((pqsigfunc)-1)

Definition at line 149 of file win32_port.h.

Referenced by pgwin32_dispatch_queued_signals(), pqsignal(), and pqsignal_pm().

◆ SIG_IGN

#define SIG_IGN ((pqsigfunc)1)

◆ SIGABRT

#define SIGABRT 22 /* Set to match W32 value -- not UNIX value */

Definition at line 156 of file win32_port.h.

Referenced by pqinitmask(), and set_sig().

◆ SIGALRM

#define SIGALRM 14

Definition at line 159 of file win32_port.h.

Referenced by BackgroundWriterMain(), CheckpointerMain(), InitializeTimeouts(), main(), pg_timer_thread(), PgArchiverMain(), PgstatCollectorMain(), PostmasterMain(), pqinitmask(), pqsignal(), setalarm(), SysLoggerMain(), WalReceiverMain(), and WalWriterMain().

◆ SIGCHLD

#define SIGCHLD 20

Definition at line 163 of file win32_port.h.

Referenced by AutoVacLauncherMain(), AutoVacWorkerMain(), BackgroundWriterMain(), CheckpointerMain(), PgArchiverMain(), PgstatCollectorMain(), PostgresMain(), PostmasterMain(), PostmasterMarkPIDForWorkerNotify(), pqsignal(), pqsignal_pm(), StartBackgroundWorker(), StartupProcessMain(), SysLoggerMain(), WalReceiverMain(), WalSndSignals(), and WalWriterMain().

◆ SIGCONT

#define SIGCONT 19

Definition at line 162 of file win32_port.h.

Referenced by pqinitmask().

◆ SIGHUP

#define SIGHUP 1

◆ SIGKILL

#define SIGKILL 9

Definition at line 157 of file win32_port.h.

Referenced by regression_main(), ServerLoop(), set_sig(), signal_child(), and TerminateChildren().

◆ sigmask

#define sigmask ( sig ) ( 1 << ((sig)-1) )

Definition at line 142 of file win32_port.h.

Referenced by pg_queue_signal(), and pgwin32_dispatch_queued_signals().

◆ SIGPIPE

#define SIGPIPE 13

◆ SIGQUIT

#define SIGQUIT 3

Definition at line 154 of file win32_port.h.

Referenced by bootstrap_signals(), HandleChildCrash(), InitPostmasterChild(), main(), PgstatCollectorMain(), pmdie(), PostgresMain(), PostmasterMain(), PostmasterStateMachine(), pqinitmask(), quickdie(), reaper(), ServerLoop(), set_mode(), set_sig(), setup_cancel_handler(), setup_signals(), signal_child(), sigTermHandler(), SysLoggerMain(), and TerminateChildren().

◆ SIGSTOP

#define SIGSTOP 17

Definition at line 160 of file win32_port.h.

Referenced by HandleChildCrash(), and signal_child().

◆ SIGTRAP

#define SIGTRAP 5

Definition at line 155 of file win32_port.h.

Referenced by pqinitmask().

◆ SIGTSTP

#define SIGTSTP 18

Definition at line 161 of file win32_port.h.

◆ SIGUSR1

◆ SIGUSR2

#define SIGUSR2 31

Definition at line 166 of file win32_port.h.

Referenced by AutoVacLauncherMain(), AutoVacWorkerMain(), BackgroundWriterMain(), CheckpointerMain(), PgArchiverMain(), PgstatCollectorMain(), PostgresMain(), PostmasterMain(), PostmasterStateMachine(), ProcKill(), reaper(), ServerLoop(), set_sig(), sigusr1_handler(), StartBackgroundWorker(), StartupProcessMain(), SysLoggerMain(), WalReceiverMain(), WalSndSignals(), and WalWriterMain().

◆ SIGWINCH

#define SIGWINCH 28

Definition at line 164 of file win32_port.h.

◆ socket

#define socket	(	af,
		type,
		protocol
	)	pgwin32_socket(af, type, protocol)

Definition at line 431 of file win32_port.h.

Referenced by ident_inet(), internal_cancel(), PerformRadiusTransaction(), pgstat_init(), PQconnectPoll(), readMessageFromPipe(), run_ifaddr_callback(), and StreamServerPort().

◆ stat

#define stat	(	a,
		b
	)	pgwin32_safestat(a,b)

Definition at line 255 of file win32_port.h.

Referenced by _discoverArchiveFormat(), _PrepParallelRestore(), AlterSystemSetConfigFile(), BackupInProgress(), BeginCopyFrom(), BeginCopyTo(), bt_page_stats(), BuildRelationExtStatistics(), calculate_relation_size(), calculate_tablespace_size(), CancelBackup(), check_bin_dir(), check_db_file_conflict(), check_input(), check_single_dir(), check_ssl_key_file_permissions(), checkDataDir(), CheckForExternalTrigger(), CheckForStandbyTrigger(), CheckLogrotateSignal(), CheckPointLogicalRewriteHeap(), CheckPointSnapBuild(), CheckPromoteSignal(), cmp_abs(), cmp_abs_common(), ComputeExtStatisticsRows(), copydir(), create_tablespace_directories(), createdb(), CreateExtensionInternal(), CreateSlotOnDisk(), CustomizableInitialize(), CustomizableNextWALFileReady(), db_dir_size(), dbase_redo(), dependencies_clauselist_selectivity(), destroy_tablespace_directories(), dir_get_file_size(), directory_exists(), do_copy(), do_edit(), do_pg_start_backup(), do_pg_stop_backup(), do_restart(), do_stop(), dsm_impl_mmap(), dsm_impl_op(), estimate_size(), file_exists(), fileAnalyzeForeignTable(), FileClose(), fileExplainForeignScan(), FindStreamingStart(), get_dirent_type(), get_pgpid(), get_tablespace_paths(), GETTEMP(), has_stats_of_kind(), hash_page_stats(), ImportSnapshot(), InitArchiveFmt_Directory(), Initialize(), initialize_SSL(), InstallXLogFileSegment(), internal_load_library(), internal_unload_library(), itsdir(), KeepFileRestoredFromArchive(), parse_manifest_file(), parseServiceInfo(), passwordFromFile(), PathNameDeleteTemporaryDir(), PathNameDeleteTemporaryFile(), perform_base_backup(), pg_file_sync(), pg_file_write_internal(), pg_fsync(), pg_ls_dir_files(), pg_mkdir_p(), pg_stat_file(), pg_stat_get_slru(), pg_tzenumerate_next(), pgarch_ArchiverCopyLoop(), PGReserveSemaphores(), PGSharedMemoryAttach(), PGSharedMemoryCreate(), pgstat_heap(), pgstat_index(), pgstattuple_approx_internal(), PGTYPESnumeric_div(), process_source_file(), PutMemoryContextsStatsTupleStore(), qtext_load_file(), read_whole_file(), readfile(), readRecoverySignalFile(), ReadTwoPhaseFile(), recurse_dir(), remove_dbtablespaces(), remove_tablespace_symlink(), RemovePgTempFilesInDir(), RemoveXlogFile(), ReorderBufferCleanupSerializedTXNs(), resolve_symlinks(), RestoreArchivedFile(), rewriteVisibilityMap(), rmtree(), scan_available_timezones(), scan_directory(), SelectConfigFiles(), sendDir(), sendFileWithContent(), sendTablespace(), SetDataDirectoryCreatePerm(), slurpFile(), SnapBuildSerialize(), sqrt_var(), StartupReplicationSlots(), StartupXLOG(), statext_mcv_clauselist_selectivity(), StreamLogicalLog(), SyncDataDirectory(), TablespaceCreateDbspace(), transfer_relfile(), ts_accum(), ts_stat1(), ts_stat2(), ts_stat_sql(), validate_exec(), ValidateXLOGDirectoryStructure(), verify_backup_file(), XLogArchiveCheckDone(), XLogArchiveForceDone(), XLogArchiveIsBusy(), XLogArchiveIsReady(), and XLogArchiveIsReadyOrDone().

◆ strcoll_l

#define strcoll_l _strcoll_l

Definition at line 386 of file win32_port.h.

Referenced by varstr_cmp(), and varstrfastcmp_locale().

◆ strxfrm_l

#define strxfrm_l _strxfrm_l

Definition at line 387 of file win32_port.h.

Referenced by varstr_abbrev_convert().

◆ symlink

#define symlink	(	oldpath,
		newpath
	)	pgsymlink(oldpath, newpath)

Definition at line 221 of file win32_port.h.

Referenced by create_tablespace_directories(), create_target_symlink(), create_xlog_or_symlink(), dolink(), main(), ReceiveTarAndUnpackCopyChunk(), and StartupXLOG().

◆ tolower_l

#define tolower_l _tolower_l

Definition at line 364 of file win32_port.h.

Referenced by pg_wc_tolower(), SB_lower_char(), str_initcap(), and str_tolower().

◆ toupper_l

#define toupper_l _toupper_l

Definition at line 365 of file win32_port.h.

Referenced by pg_wc_toupper(), str_initcap(), and str_toupper().

◆ towlower_l

#define towlower_l _towlower_l

Definition at line 366 of file win32_port.h.

Referenced by pg_wc_tolower(), str_initcap(), and str_tolower().

◆ towupper_l

#define towupper_l _towupper_l

Definition at line 367 of file win32_port.h.

Referenced by pg_wc_toupper(), str_initcap(), and str_toupper().

◆ UNBLOCKED_SIGNAL_QUEUE

#define UNBLOCKED_SIGNAL_QUEUE ( ) (pg_signal_queue & ~pg_signal_mask)

Definition at line 417 of file win32_port.h.

Referenced by pgwin32_dispatch_queued_signals(), and pgwin32_poll_signals().

◆ unsetenv

#define unsetenv ( x ) pgwin32_unsetenv(x)

Definition at line 475 of file win32_port.h.

Referenced by bootstrap_template1(), ecpg_start_test(), exec_command_setenv(), initialize_environment(), isolation_start_test(), main(), pg_putenv(), and psql_start_test().

◆ USES_WINSOCK

#define USES_WINSOCK

Definition at line 72 of file win32_port.h.

◆ wcscoll_l

#define wcscoll_l _wcscoll_l

Definition at line 388 of file win32_port.h.

Referenced by varstr_cmp().

◆ wcstombs_l

#define wcstombs_l _wcstombs_l

Definition at line 389 of file win32_port.h.

Referenced by wchar2char().

◆ WEXITSTATUS

#define WEXITSTATUS ( w ) (w)

Definition at line 139 of file win32_port.h.

Referenced by log_child_failure(), LogChildExit(), pgarch_archiveXlog(), run_diff(), wait_result_is_any_signal(), wait_result_is_signal(), wait_result_to_str(), and yearistype().

◆ WIFEXITED

#define WIFEXITED ( w ) (((w) & 0XFFFFFF00) == 0)

Definition at line 137 of file win32_port.h.

Referenced by log_child_failure(), LogChildExit(), pgarch_archiveXlog(), run_diff(), wait_result_is_any_signal(), wait_result_is_signal(), wait_result_to_str(), and yearistype().

◆ WIFSIGNALED

#define WIFSIGNALED ( w ) (!WIFEXITED(w))

Definition at line 138 of file win32_port.h.

Referenced by log_child_failure(), LogChildExit(), pgarch_archiveXlog(), wait_result_is_any_signal(), wait_result_is_signal(), and wait_result_to_str().

◆ WTERMSIG

#define WTERMSIG ( w ) (w)

Definition at line 140 of file win32_port.h.

Referenced by log_child_failure(), LogChildExit(), pgarch_archiveXlog(), wait_result_is_signal(), and wait_result_to_str().

Typedef Documentation

◆ gid_t

typedef int gid_t

Definition at line 231 of file win32_port.h.

◆ key_t

typedef long key_t

Definition at line 233 of file win32_port.h.

◆ uid_t

typedef int uid_t

Definition at line 230 of file win32_port.h.

Function Documentation

◆ _dosmaperr()

void _dosmaperr ( unsigned long )

Definition at line 171 of file win32error.c.

References DEBUG5, doserr, doserrors, ereport, errmsg_internal(), fprintf, i, lengthof, LOG, and winerr.

Referenced by BaseBackup(), copyFile(), dsm_impl_pin_segment(), dsm_impl_sysv(), dsm_impl_unpin_segment(), FileRead(), FileWrite(), getrusage(), mkdirs(), pg_pread(), pg_pwrite(), readdir(), socket_has_input(), and write_syslogger_file().

 {
     int         i;
 
     if (e == 0)
     {
         errno = 0;
         return;
     }
 
     for (i = 0; i < lengthof(doserrors); i++)
     {
         if (doserrors[i].winerr == e)
         {
             int         doserr = doserrors[i].doserr;
 
 #ifndef FRONTEND
             ereport(DEBUG5,
                     (errmsg_internal("mapped win32 error code %lu to %d",
                                      e, doserr)));
 #elif defined(FRONTEND_DEBUG)
             fprintf(stderr, "mapped win32 error code %lu to %d", e, doserr);
 #endif
             errno = doserr;
             return;
         }
     }
 
 #ifndef FRONTEND
     ereport(LOG,
             (errmsg_internal("unrecognized win32 error code: %lu",
                              e)));
 #else
     fprintf(stderr, "unrecognized win32 error code: %lu", e);
 #endif
 
     errno = EINVAL;
 }

◆ AddUserToTokenDacl()

BOOL AddUserToTokenDacl ( HANDLE hToken )

Referenced by do_kill(), and set_pglocale_pgservice().

◆ pg_queue_signal()

void pg_queue_signal ( int signum )

Definition at line 215 of file signal.c.

References Assert, PG_SIGNAL_COUNT, pg_signal_crit_sec, pg_signal_queue, pgwin32_signal_event, and sigmask.

Referenced by pg_console_handler(), pg_signal_thread(), pg_timer_thread(), and PostmasterMarkPIDForWorkerNotify().

 {
     Assert(pgwin32_signal_event != NULL);
     if (signum >= PG_SIGNAL_COUNT || signum <= 0)
         return;                 /* ignore any bad signal number */
 
     EnterCriticalSection(&pg_signal_crit_sec);
     pg_signal_queue |= sigmask(signum);
     LeaveCriticalSection(&pg_signal_crit_sec);
 
     SetEvent(pgwin32_signal_event);
 }

◆ pgkill()

int pgkill	(	int	pid,
		int	sig
	)

◆ pgreadlink()

int pgreadlink	(	const char *	path,
		char *	buf,
		size_t	size
	)

◆ pgsymlink()

int pgsymlink	(	const char *	oldpath,
		const char *	newpath
	)

◆ pgwin32_accept()

SOCKET pgwin32_accept	(	SOCKET	s,
		struct sockaddr *	addr,
		int *	addrlen
	)

Definition at line 323 of file socket.c.

References pgwin32_poll_signals(), and TranslateSocketError().

 {
     SOCKET      rs;
 
     /*
      * Poll for signals, but don't return with EINTR, since we don't handle
      * that in pqcomm.c
      */
     pgwin32_poll_signals();
 
     rs = WSAAccept(s, addr, addrlen, NULL, 0);
     if (rs == INVALID_SOCKET)
     {
         TranslateSocketError();
         return INVALID_SOCKET;
     }
     return rs;
 }

◆ pgwin32_bind()

int pgwin32_bind	(	SOCKET	s,
		struct sockaddr *	addr,
		int	addrlen
	)

Definition at line 301 of file socket.c.

References bind, and TranslateSocketError().

 {
     int         res;
 
     res = bind(s, addr, addrlen);
     if (res < 0)
         TranslateSocketError();
     return res;
 }

◆ pgwin32_connect()

int pgwin32_connect	(	SOCKET	s,
		const struct sockaddr *	name,
		int	namelen
	)

Definition at line 345 of file socket.c.

References pgwin32_waitforsinglesocket(), and TranslateSocketError().

 {
     int         r;
 
     r = WSAConnect(s, addr, addrlen, NULL, NULL, NULL, NULL);
     if (r == 0)
         return 0;
 
     if (WSAGetLastError() != WSAEWOULDBLOCK)
     {
         TranslateSocketError();
         return -1;
     }
 
     while (pgwin32_waitforsinglesocket(s, FD_CONNECT, INFINITE) == 0)
     {
         /* Loop endlessly as long as we are just delivering signals */
     }
 
     return 0;
 }

◆ pgwin32_create_signal_listener()

HANDLE pgwin32_create_signal_listener ( pid_t pid )

Definition at line 183 of file signal.c.

References ereport, errmsg(), ERROR, and snprintf.

Referenced by PostmasterMarkPIDForWorkerNotify().

 {
     char        pipename[128];
     HANDLE      pipe;
 
     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);
 
     if (pipe == INVALID_HANDLE_VALUE)
         ereport(ERROR,
                 (errmsg("could not create signal listener pipe for PID %d: error code %lu",
                         (int) pid, GetLastError())));
 
     return pipe;
 }

◆ pgwin32_dispatch_queued_signals()

void pgwin32_dispatch_queued_signals ( void )

Definition at line 108 of file signal.c.

References Assert, i, pg_signal_array, PG_SIGNAL_COUNT, pg_signal_crit_sec, pg_signal_defaults, pg_signal_queue, pgwin32_signal_event, sig, SIG_DFL, SIG_ERR, SIG_IGN, sigmask, and UNBLOCKED_SIGNAL_QUEUE.

Referenced by pg_usleep(), PGSemaphoreLock(), pgwin32_poll_signals(), pgwin32_select(), pgwin32_waitforsinglesocket(), pqsigsetmask(), and WaitEventSetWait().

 {
     int         exec_mask;
 
     Assert(pgwin32_signal_event != NULL);
     EnterCriticalSection(&pg_signal_crit_sec);
     while ((exec_mask = UNBLOCKED_SIGNAL_QUEUE()) != 0)
     {
         /* One or more unblocked signals queued for execution */
         int         i;
 
         for (i = 1; i < PG_SIGNAL_COUNT; i++)
         {
             if (exec_mask & sigmask(i))
             {
                 /* Execute this signal */
                 pqsigfunc   sig = pg_signal_array[i];
 
                 if (sig == SIG_DFL)
                     sig = pg_signal_defaults[i];
                 pg_signal_queue &= ~sigmask(i);
                 if (sig != SIG_ERR && sig != SIG_IGN && sig != SIG_DFL)
                 {
                     LeaveCriticalSection(&pg_signal_crit_sec);
                     sig(i);
                     EnterCriticalSection(&pg_signal_crit_sec);
                     break;      /* Restart outer loop, in case signal mask or
                                  * queue has been modified inside signal
                                  * handler */
                 }
             }
         }
     }
     ResetEvent(pgwin32_signal_event);
     LeaveCriticalSection(&pg_signal_crit_sec);
 }

◆ pgwin32_install_crashdump_handler()

void pgwin32_install_crashdump_handler ( void )

Definition at line 180 of file crashdump.c.

References crashDumpHandler().

Referenced by main().

 {
     SetUnhandledExceptionFilter(crashDumpHandler);
 }

◆ pgwin32_is_admin()

int pgwin32_is_admin ( void )

Definition at line 49 of file win32security.c.

References _, and log_error.

Referenced by check_root().

 {
     PSID        AdministratorsSid;
     PSID        PowerUsersSid;
     SID_IDENTIFIER_AUTHORITY NtAuthority = {SECURITY_NT_AUTHORITY};
     BOOL        IsAdministrators;
     BOOL        IsPowerUsers;
 
     if (!AllocateAndInitializeSid(&NtAuthority, 2,
                                   SECURITY_BUILTIN_DOMAIN_RID,
                                   DOMAIN_ALIAS_RID_ADMINS, 0, 0, 0, 0, 0,
                                   0, &AdministratorsSid))
     {
         log_error(_("could not get SID for Administrators group: error code %lu\n"),
                   GetLastError());
         exit(1);
     }
 
     if (!AllocateAndInitializeSid(&NtAuthority, 2,
                                   SECURITY_BUILTIN_DOMAIN_RID,
                                   DOMAIN_ALIAS_RID_POWER_USERS, 0, 0, 0, 0, 0,
                                   0, &PowerUsersSid))
     {
         log_error(_("could not get SID for PowerUsers group: error code %lu\n"),
                   GetLastError());
         exit(1);
     }
 
     if (!CheckTokenMembership(NULL, AdministratorsSid, &IsAdministrators) ||
         !CheckTokenMembership(NULL, PowerUsersSid, &IsPowerUsers))
     {
         log_error(_("could not check access token membership: error code %lu\n"),
                   GetLastError());
         exit(1);
     }
 
     FreeSid(AdministratorsSid);
     FreeSid(PowerUsersSid);
 
     if (IsAdministrators || IsPowerUsers)
         return 1;
     else
         return 0;
 }

◆ pgwin32_is_junction()

bool pgwin32_is_junction ( const char * path )

Referenced by _tarWriteDir(), process_source_file(), recurse_dir(), scan_directory(), sendDir(), and SyncDataDirectory().

◆ pgwin32_is_service()

int pgwin32_is_service ( void )

Definition at line 117 of file win32security.c.

References fprintf.

Referenced by send_message_to_server_log(), and write_stderr().

 {
     static int  _is_service = -1;
     BOOL        IsMember;
     PSID        ServiceSid;
     PSID        LocalSystemSid;
     SID_IDENTIFIER_AUTHORITY NtAuthority = {SECURITY_NT_AUTHORITY};
 
     /* Only check the first time */
     if (_is_service != -1)
         return _is_service;
 
     /* First check for LocalSystem */
     if (!AllocateAndInitializeSid(&NtAuthority, 1,
                                   SECURITY_LOCAL_SYSTEM_RID, 0, 0, 0, 0, 0, 0, 0,
                                   &LocalSystemSid))
     {
         fprintf(stderr, "could not get SID for local system account\n");
         return -1;
     }
 
     if (!CheckTokenMembership(NULL, LocalSystemSid, &IsMember))
     {
         fprintf(stderr, "could not check access token membership: error code %lu\n",
                 GetLastError());
         FreeSid(LocalSystemSid);
         return -1;
     }
     FreeSid(LocalSystemSid);
 
     if (IsMember)
     {
         _is_service = 1;
         return _is_service;
     }
 
     /* Check for service group membership */
     if (!AllocateAndInitializeSid(&NtAuthority, 1,
                                   SECURITY_SERVICE_RID, 0, 0, 0, 0, 0, 0, 0,
                                   &ServiceSid))
     {
         fprintf(stderr, "could not get SID for service group: error code %lu\n",
                 GetLastError());
         return -1;
     }
 
     if (!CheckTokenMembership(NULL, ServiceSid, &IsMember))
     {
         fprintf(stderr, "could not check access token membership: error code %lu\n",
                 GetLastError());
         FreeSid(ServiceSid);
         return -1;
     }
     FreeSid(ServiceSid);
 
     if (IsMember)
         _is_service = 1;
     else
         _is_service = 0;
 
     return _is_service;
 }

◆ pgwin32_listen()

int pgwin32_listen	(	SOCKET	s,
		int	backlog
	)

Definition at line 312 of file socket.c.

References listen, and TranslateSocketError().

 {
     int         res;
 
     res = listen(s, backlog);
     if (res < 0)
         TranslateSocketError();
     return res;
 }

◆ pgwin32_putenv()

int pgwin32_putenv ( const char * )

Definition at line 20 of file win32env.c.

References free, and i.

Referenced by pgwin32_unsetenv().

 {
     char       *envcpy;
     char       *cp;
     typedef int (_cdecl * PUTENVPROC) (const char *);
     static const char *const modulenames[] = {
         "msvcrt",               /* Visual Studio 6.0 / MinGW */
         "msvcrtd",
         "msvcr70",              /* Visual Studio 2002 */
         "msvcr70d",
         "msvcr71",              /* Visual Studio 2003 */
         "msvcr71d",
         "msvcr80",              /* Visual Studio 2005 */
         "msvcr80d",
         "msvcr90",              /* Visual Studio 2008 */
         "msvcr90d",
         "msvcr100",             /* Visual Studio 2010 */
         "msvcr100d",
         "msvcr110",             /* Visual Studio 2012 */
         "msvcr110d",
         "msvcr120",             /* Visual Studio 2013 */
         "msvcr120d",
         "ucrtbase",             /* Visual Studio 2015 and later */
         "ucrtbased",
         NULL
     };
     int         i;
 
     /*
      * Update process environment, making this change visible to child
      * processes and to CRTs initializing in the future.  Do this before the
      * _putenv() loop, for the benefit of any CRT that initializes during this
      * pgwin32_putenv() execution, after the loop checks that CRT.
      *
      * Need a copy of the string so we can modify it.
      */
     envcpy = strdup(envval);
     if (!envcpy)
         return -1;
     cp = strchr(envcpy, '=');
     if (cp == NULL)
     {
         free(envcpy);
         return -1;
     }
     *cp = '\0';
     cp++;
     if (strlen(cp))
     {
         /*
          * Only call SetEnvironmentVariable() when we are adding a variable,
          * not when removing it. Calling it on both crashes on at least
          * certain versions of MinGW.
          */
         if (!SetEnvironmentVariable(envcpy, cp))
         {
             free(envcpy);
             return -1;
         }
     }
     free(envcpy);
 
     /*
      * Each CRT has its own _putenv() symbol and copy of the environment.
      * Update the environment in each CRT module currently loaded, so every
      * third-party library sees this change regardless of the CRT it links
      * against.  Addresses within these modules may become invalid the moment
      * we call FreeLibrary(), so don't cache them.
      */
     for (i = 0; modulenames[i]; i++)
     {
         HMODULE     hmodule = NULL;
         BOOL        res = GetModuleHandleEx(0, modulenames[i], &hmodule);
 
         if (res != 0 && hmodule != NULL)
         {
             PUTENVPROC  putenvFunc;
 
             putenvFunc = (PUTENVPROC) GetProcAddress(hmodule, "_putenv");
             if (putenvFunc)
                 putenvFunc(envval);
             FreeLibrary(hmodule);
         }
     }
 
     /*
      * Finally, update our "own" cache.  This is redundant with the loop
      * above, except when PostgreSQL itself links to a CRT not listed above.
      * Ideally, the loop does visit all possible CRTs, making this redundant.
      */
     return _putenv(envval);
 }

◆ pgwin32_recv()

int pgwin32_recv	(	SOCKET	s,
		char *	buf,
		int	len,
		int	flags
	)

Definition at line 368 of file socket.c.

References buf, ereport, errmsg_internal(), EWOULDBLOCK, NOTICE, pg_usleep(), pgwin32_noblock, pgwin32_poll_signals(), pgwin32_waitforsinglesocket(), and TranslateSocketError().

 {
     WSABUF      wbuf;
     int         r;
     DWORD       b;
     DWORD       flags = f;
     int         n;
 
     if (pgwin32_poll_signals())
         return -1;
 
     wbuf.len = len;
     wbuf.buf = buf;
 
     r = WSARecv(s, &wbuf, 1, &b, &flags, NULL, NULL);
     if (r != SOCKET_ERROR)
         return b;               /* success */
 
     if (WSAGetLastError() != WSAEWOULDBLOCK)
     {
         TranslateSocketError();
         return -1;
     }
 
     if (pgwin32_noblock)
     {
         /*
          * No data received, and we are in "emulated non-blocking mode", so
          * return indicating that we'd block if we were to continue.
          */
         errno = EWOULDBLOCK;
         return -1;
     }
 
     /* We're in blocking mode, so wait for data */
 
     for (n = 0; n < 5; n++)
     {
         if (pgwin32_waitforsinglesocket(s, FD_READ | FD_CLOSE | FD_ACCEPT,
                                         INFINITE) == 0)
             return -1;          /* errno already set */
 
         r = WSARecv(s, &wbuf, 1, &b, &flags, NULL, NULL);
         if (r != SOCKET_ERROR)
             return b;           /* success */
         if (WSAGetLastError() != WSAEWOULDBLOCK)
         {
             TranslateSocketError();
             return -1;
         }
 
         /*
          * There seem to be cases on win2k (at least) where WSARecv can return
          * WSAEWOULDBLOCK even when pgwin32_waitforsinglesocket claims the
          * socket is readable.  In this case, just sleep for a moment and try
          * again.  We try up to 5 times - if it fails more than that it's not
          * likely to ever come back.
          */
         pg_usleep(10000);
     }
     ereport(NOTICE,
             (errmsg_internal("could not read from ready socket (after retries)")));
     errno = EWOULDBLOCK;
     return -1;
 }

◆ pgwin32_ReserveSharedMemoryRegion()

int pgwin32_ReserveSharedMemoryRegion ( HANDLE )

Definition at line 550 of file win32_shmem.c.

References Assert, elog, LOG, PROTECTIVE_REGION_SIZE, ShmemProtectiveRegion, UsedShmemSegAddr, and UsedShmemSegSize.

Referenced by BackendRun().

 {
     void       *address;
 
     Assert(ShmemProtectiveRegion != NULL);
     Assert(UsedShmemSegAddr != NULL);
     Assert(UsedShmemSegSize != 0);
 
     /* ShmemProtectiveRegion */
     address = VirtualAllocEx(hChild, ShmemProtectiveRegion,
                              PROTECTIVE_REGION_SIZE,
                              MEM_RESERVE, PAGE_NOACCESS);
     if (address == NULL)
     {
         /* Don't use FATAL since we're running in the postmaster */
         elog(LOG, "could not reserve shared memory region (addr=%p) for child %p: error code %lu",
              ShmemProtectiveRegion, hChild, GetLastError());
         return false;
     }
     if (address != ShmemProtectiveRegion)
     {
         /*
          * Should never happen - in theory if allocation granularity causes
          * strange effects it could, so check just in case.
          *
          * Don't use FATAL since we're running in the postmaster.
          */
         elog(LOG, "reserved shared memory region got incorrect address %p, expected %p",
              address, ShmemProtectiveRegion);
         return false;
     }
 
     /* UsedShmemSegAddr */
     address = VirtualAllocEx(hChild, UsedShmemSegAddr, UsedShmemSegSize,
                              MEM_RESERVE, PAGE_READWRITE);
     if (address == NULL)
     {
         elog(LOG, "could not reserve shared memory region (addr=%p) for child %p: error code %lu",
              UsedShmemSegAddr, hChild, GetLastError());
         return false;
     }
     if (address != UsedShmemSegAddr)
     {
         elog(LOG, "reserved shared memory region got incorrect address %p, expected %p",
              address, UsedShmemSegAddr);
         return false;
     }
 
     return true;
 }

◆ pgwin32_safestat()

int pgwin32_safestat	(	const char *	path,
		struct stat *	buf
	)

◆ pgwin32_select()

int pgwin32_select	(	int	nfds,
		fd_set *	readfds,
		fd_set *	writefds,
		fd_set *	exceptfds,
		const struct timeval *	timeout
	)

Definition at line 503 of file socket.c.

References Assert, buf, EINTR, elog, ERROR, i, pgwin32_dispatch_queued_signals(), pgwin32_poll_signals(), pgwin32_signal_event, and TranslateSocketError().

 {
     WSAEVENT    events[FD_SETSIZE * 2]; /* worst case is readfds totally
                                          * different from writefds, so
                                          * 2*FD_SETSIZE sockets */
     SOCKET      sockets[FD_SETSIZE * 2];
     int         numevents = 0;
     int         i;
     int         r;
     DWORD       timeoutval = WSA_INFINITE;
     FD_SET      outreadfds;
     FD_SET      outwritefds;
     int         nummatches = 0;
 
     Assert(exceptfds == NULL);
 
     if (pgwin32_poll_signals())
         return -1;
 
     FD_ZERO(&outreadfds);
     FD_ZERO(&outwritefds);
 
     /*
      * Windows does not guarantee to log an FD_WRITE network event indicating
      * that more data can be sent unless the previous send() failed with
      * WSAEWOULDBLOCK.  While our caller might well have made such a call, we
      * cannot assume that here.  Therefore, if waiting for write-ready, force
      * the issue by doing a dummy send().  If the dummy send() succeeds,
      * assume that the socket is in fact write-ready, and return immediately.
      * Also, if it fails with something other than WSAEWOULDBLOCK, return a
      * write-ready indication to let our caller deal with the error condition.
      */
     if (writefds != NULL)
     {
         for (i = 0; i < writefds->fd_count; i++)
         {
             char        c;
             WSABUF      buf;
             DWORD       sent;
 
             buf.buf = &c;
             buf.len = 0;
 
             r = WSASend(writefds->fd_array[i], &buf, 1, &sent, 0, NULL, NULL);
             if (r == 0 || WSAGetLastError() != WSAEWOULDBLOCK)
                 FD_SET(writefds->fd_array[i], &outwritefds);
         }
 
         /* If we found any write-ready sockets, just return them immediately */
         if (outwritefds.fd_count > 0)
         {
             memcpy(writefds, &outwritefds, sizeof(fd_set));
             if (readfds)
                 FD_ZERO(readfds);
             return outwritefds.fd_count;
         }
     }
 
 
     /* Now set up for an actual select */
 
     if (timeout != NULL)
     {
         /* timeoutval is in milliseconds */
         timeoutval = timeout->tv_sec * 1000 + timeout->tv_usec / 1000;
     }
 
     if (readfds != NULL)
     {
         for (i = 0; i < readfds->fd_count; i++)
         {
             events[numevents] = WSACreateEvent();
             sockets[numevents] = readfds->fd_array[i];
             numevents++;
         }
     }
     if (writefds != NULL)
     {
         for (i = 0; i < writefds->fd_count; i++)
         {
             if (!readfds ||
                 !FD_ISSET(writefds->fd_array[i], readfds))
             {
                 /* If the socket is not in the read list */
                 events[numevents] = WSACreateEvent();
                 sockets[numevents] = writefds->fd_array[i];
                 numevents++;
             }
         }
     }
 
     for (i = 0; i < numevents; i++)
     {
         int         flags = 0;
 
         if (readfds && FD_ISSET(sockets[i], readfds))
             flags |= FD_READ | FD_ACCEPT | FD_CLOSE;
 
         if (writefds && FD_ISSET(sockets[i], writefds))
             flags |= FD_WRITE | FD_CLOSE;
 
         if (WSAEventSelect(sockets[i], events[i], flags) != 0)
         {
             TranslateSocketError();
             /* release already-assigned event objects */
             while (--i >= 0)
                 WSAEventSelect(sockets[i], NULL, 0);
             for (i = 0; i < numevents; i++)
                 WSACloseEvent(events[i]);
             return -1;
         }
     }
 
     events[numevents] = pgwin32_signal_event;
     r = WaitForMultipleObjectsEx(numevents + 1, events, FALSE, timeoutval, TRUE);
     if (r != WAIT_TIMEOUT && r != WAIT_IO_COMPLETION && r != (WAIT_OBJECT_0 + numevents))
     {
         /*
          * We scan all events, even those not signaled, in case more than one
          * event has been tagged but Wait.. can only return one.
          */
         WSANETWORKEVENTS resEvents;
 
         for (i = 0; i < numevents; i++)
         {
             ZeroMemory(&resEvents, sizeof(resEvents));
             if (WSAEnumNetworkEvents(sockets[i], events[i], &resEvents) != 0)
                 elog(ERROR, "failed to enumerate network events: error code %u",
                      WSAGetLastError());
             /* Read activity? */
             if (readfds && FD_ISSET(sockets[i], readfds))
             {
                 if ((resEvents.lNetworkEvents & FD_READ) ||
                     (resEvents.lNetworkEvents & FD_ACCEPT) ||
                     (resEvents.lNetworkEvents & FD_CLOSE))
                 {
                     FD_SET(sockets[i], &outreadfds);
 
                     nummatches++;
                 }
             }
             /* Write activity? */
             if (writefds && FD_ISSET(sockets[i], writefds))
             {
                 if ((resEvents.lNetworkEvents & FD_WRITE) ||
                     (resEvents.lNetworkEvents & FD_CLOSE))
                 {
                     FD_SET(sockets[i], &outwritefds);
 
                     nummatches++;
                 }
             }
         }
     }
 
     /* Clean up all the event objects */
     for (i = 0; i < numevents; i++)
     {
         WSAEventSelect(sockets[i], NULL, 0);
         WSACloseEvent(events[i]);
     }
 
     if (r == WSA_WAIT_TIMEOUT)
     {
         if (readfds)
             FD_ZERO(readfds);
         if (writefds)
             FD_ZERO(writefds);
         return 0;
     }
 
     /* Signal-like events. */
     if (r == WAIT_OBJECT_0 + numevents || r == WAIT_IO_COMPLETION)
     {
         pgwin32_dispatch_queued_signals();
         errno = EINTR;
         if (readfds)
             FD_ZERO(readfds);
         if (writefds)
             FD_ZERO(writefds);
         return -1;
     }
 
     /* Overwrite socket sets with our resulting values */
     if (readfds)
         memcpy(readfds, &outreadfds, sizeof(fd_set));
     if (writefds)
         memcpy(writefds, &outwritefds, sizeof(fd_set));
     return nummatches;
 }

◆ pgwin32_send()

int pgwin32_send	(	SOCKET	s,
		const void *	buf,
		int	len,
		int	flags
	)

Definition at line 445 of file socket.c.

References EWOULDBLOCK, pgwin32_noblock, pgwin32_poll_signals(), pgwin32_waitforsinglesocket(), and TranslateSocketError().

 {
     WSABUF      wbuf;
     int         r;
     DWORD       b;
 
     if (pgwin32_poll_signals())
         return -1;
 
     wbuf.len = len;
     wbuf.buf = (char *) buf;
 
     /*
      * Readiness of socket to send data to UDP socket may be not true: socket
      * can become busy again! So loop until send or error occurs.
      */
     for (;;)
     {
         r = WSASend(s, &wbuf, 1, &b, flags, NULL, NULL);
         if (r != SOCKET_ERROR && b > 0)
             /* Write succeeded right away */
             return b;
 
         if (r == SOCKET_ERROR &&
             WSAGetLastError() != WSAEWOULDBLOCK)
         {
             TranslateSocketError();
             return -1;
         }
 
         if (pgwin32_noblock)
         {
             /*
              * No data sent, and we are in "emulated non-blocking mode", so
              * return indicating that we'd block if we were to continue.
              */
             errno = EWOULDBLOCK;
             return -1;
         }
 
         /* No error, zero bytes (win2000+) or error+WSAEWOULDBLOCK (<=nt4) */
 
         if (pgwin32_waitforsinglesocket(s, FD_WRITE | FD_CLOSE, INFINITE) == 0)
             return -1;
     }
 
     return -1;
 }

◆ pgwin32_setlocale()

char* pgwin32_setlocale	(	int	category,
		const char *	locale
	)

Definition at line 172 of file win32setlocale.c.

References map_locale(), setlocale, and unconstify.

 {
     const char *argument;
     char       *result;
 
     if (locale == NULL)
         argument = NULL;
     else
         argument = map_locale(locale_map_argument, locale);
 
     /* Call the real setlocale() function */
     result = setlocale(category, argument);
 
     /*
      * setlocale() is specified to return a "char *" that the caller is
      * forbidden to modify, so casting away the "const" is innocuous.
      */
     if (result)
         result = unconstify(char *, map_locale(locale_map_result, result));
 
     return result;
 }

◆ pgwin32_signal_initialize()

void pgwin32_signal_initialize ( void )

Definition at line 69 of file signal.c.

References ereport, errmsg_internal(), FATAL, i, pg_console_handler(), pg_signal_array, PG_SIGNAL_COUNT, pg_signal_crit_sec, pg_signal_defaults, pg_signal_mask, pg_signal_queue, pg_signal_thread(), pgwin32_signal_event, SIG_DFL, and SIG_IGN.

Referenced by BackendRun(), and main().

 {
     int         i;
     HANDLE      signal_thread_handle;
 
     InitializeCriticalSection(&pg_signal_crit_sec);
 
     for (i = 0; i < PG_SIGNAL_COUNT; i++)
     {
         pg_signal_array[i] = SIG_DFL;
         pg_signal_defaults[i] = SIG_IGN;
     }
     pg_signal_mask = 0;
     pg_signal_queue = 0;
 
     /* Create the global event handle used to flag signals */
     pgwin32_signal_event = CreateEvent(NULL, TRUE, FALSE, NULL);
     if (pgwin32_signal_event == NULL)
         ereport(FATAL,
                 (errmsg_internal("could not create signal event: error code %lu", GetLastError())));
 
     /* Create thread for handling signals */
     signal_thread_handle = CreateThread(NULL, 0, pg_signal_thread, NULL, 0, NULL);
     if (signal_thread_handle == NULL)
         ereport(FATAL,
                 (errmsg_internal("could not create signal handler thread")));
 
     /* Create console control handle to pick up Ctrl-C etc */
     if (!SetConsoleCtrlHandler(pg_console_handler, TRUE))
         ereport(FATAL,
                 (errmsg_internal("could not set console control handler")));
 }

◆ pgwin32_socket()

SOCKET pgwin32_socket	(	int	af,
		int	type,
		int	protocol
	)

Definition at line 278 of file socket.c.

References TranslateSocketError().

 {
     SOCKET      s;
     unsigned long on = 1;
 
     s = WSASocket(af, type, protocol, NULL, 0, WSA_FLAG_OVERLAPPED);
     if (s == INVALID_SOCKET)
     {
         TranslateSocketError();
         return INVALID_SOCKET;
     }
 
     if (ioctlsocket(s, FIONBIO, &on))
     {
         TranslateSocketError();
         return INVALID_SOCKET;
     }
     errno = 0;
 
     return s;
 }

◆ pgwin32_unsetenv()

void pgwin32_unsetenv ( const char * )

Definition at line 114 of file win32env.c.

References free, malloc, pgwin32_putenv(), and sprintf.

 {
     char       *envbuf;
 
     envbuf = (char *) malloc(strlen(name) + 2);
     if (!envbuf)
         return;
 
     sprintf(envbuf, "%s=", name);
     pgwin32_putenv(envbuf);
     free(envbuf);
 }

◆ pgwin32_waitforsinglesocket()

int pgwin32_waitforsinglesocket	(	SOCKET	s,
		int	what,
		int	timeout
	)

Definition at line 168 of file socket.c.

References buf, EINTR, ereport, errmsg_internal(), ERROR, EWOULDBLOCK, isDataGram(), pgwin32_dispatch_queued_signals(), pgwin32_signal_event, and TranslateSocketError().

Referenced by pgwin32_connect(), pgwin32_recv(), and pgwin32_send().

 {
     static HANDLE waitevent = INVALID_HANDLE_VALUE;
     static SOCKET current_socket = INVALID_SOCKET;
     static int  isUDP = 0;
     HANDLE      events[2];
     int         r;
 
     /* Create an event object just once and use it on all future calls */
     if (waitevent == INVALID_HANDLE_VALUE)
     {
         waitevent = CreateEvent(NULL, TRUE, FALSE, NULL);
 
         if (waitevent == INVALID_HANDLE_VALUE)
             ereport(ERROR,
                     (errmsg_internal("could not create socket waiting event: error code %lu", GetLastError())));
     }
     else if (!ResetEvent(waitevent))
         ereport(ERROR,
                 (errmsg_internal("could not reset socket waiting event: error code %lu", GetLastError())));
 
     /*
      * Track whether socket is UDP or not.  (NB: most likely, this is both
      * useless and wrong; there is no reason to think that the behavior of
      * WSAEventSelect is different for TCP and UDP.)
      */
     if (current_socket != s)
         isUDP = isDataGram(s);
     current_socket = s;
 
     /*
      * Attach event to socket.  NOTE: we must detach it again before
      * returning, since other bits of code may try to attach other events to
      * the socket.
      */
     if (WSAEventSelect(s, waitevent, what) != 0)
     {
         TranslateSocketError();
         return 0;
     }
 
     events[0] = pgwin32_signal_event;
     events[1] = waitevent;
 
     /*
      * Just a workaround of unknown locking problem with writing in UDP socket
      * under high load: Client's pgsql backend sleeps infinitely in
      * WaitForMultipleObjectsEx, pgstat process sleeps in pgwin32_select().
      * So, we will wait with small timeout(0.1 sec) and if socket is still
      * blocked, try WSASend (see comments in pgwin32_select) and wait again.
      */
     if ((what & FD_WRITE) && isUDP)
     {
         for (;;)
         {
             r = WaitForMultipleObjectsEx(2, events, FALSE, 100, TRUE);
 
             if (r == WAIT_TIMEOUT)
             {
                 char        c;
                 WSABUF      buf;
                 DWORD       sent;
 
                 buf.buf = &c;
                 buf.len = 0;
 
                 r = WSASend(s, &buf, 1, &sent, 0, NULL, NULL);
                 if (r == 0)     /* Completed - means things are fine! */
                 {
                     WSAEventSelect(s, NULL, 0);
                     return 1;
                 }
                 else if (WSAGetLastError() != WSAEWOULDBLOCK)
                 {
                     TranslateSocketError();
                     WSAEventSelect(s, NULL, 0);
                     return 0;
                 }
             }
             else
                 break;
         }
     }
     else
         r = WaitForMultipleObjectsEx(2, events, FALSE, timeout, TRUE);
 
     WSAEventSelect(s, NULL, 0);
 
     if (r == WAIT_OBJECT_0 || r == WAIT_IO_COMPLETION)
     {
         pgwin32_dispatch_queued_signals();
         errno = EINTR;
         return 0;
     }
     if (r == WAIT_OBJECT_0 + 1)
         return 1;
     if (r == WAIT_TIMEOUT)
     {
         errno = EWOULDBLOCK;
         return 0;
     }
     ereport(ERROR,
             (errmsg_internal("unrecognized return value from WaitForMultipleObjects: %d (error code %lu)", r, GetLastError())));
     return 0;
 }

◆ setitimer()

int setitimer	(	int	which,
		const struct itimerval *	value,
		struct itimerval *	ovalue
	)

Definition at line 86 of file timer.c.

References Assert, timerCA::crit_sec, ereport, errmsg_internal(), timerCA::event, FATAL, itimerval::it_interval, ITIMER_REAL, MemSet, pg_timer_thread(), timerThreadHandle, and timerCA::value.

Referenced by disable_all_timeouts(), fork_process(), and schedule_alarm().

 {
     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;
 }

Variable Documentation

◆ pg_signal_mask

PGDLLIMPORT int pg_signal_mask

Definition at line 25 of file signal.c.

Referenced by pgwin32_signal_initialize(), and pqsigsetmask().

◆ pg_signal_queue

PGDLLIMPORT volatile int pg_signal_queue

Definition at line 24 of file signal.c.

Referenced by pg_queue_signal(), pgwin32_dispatch_queued_signals(), and pgwin32_signal_initialize().

◆ pgwin32_initial_signal_pipe

HANDLE pgwin32_initial_signal_pipe

Definition at line 28 of file signal.c.

Referenced by pg_signal_thread(), and PostmasterMarkPIDForWorkerNotify().

◆ pgwin32_noblock

int pgwin32_noblock

Definition at line 28 of file socket.c.

Referenced by PgstatCollectorMain(), pgwin32_recv(), pgwin32_send(), secure_raw_read(), and secure_raw_write().

◆ pgwin32_signal_event

HANDLE pgwin32_signal_event

Definition at line 27 of file signal.c.

Referenced by CreateWaitEventSet(), pg_queue_signal(), pg_usleep(), PGSemaphoreLock(), pgwin32_dispatch_queued_signals(), pgwin32_select(), pgwin32_signal_initialize(), and pgwin32_waitforsinglesocket().

Data Structures

Macros

Typedefs

Functions

Variables

Macro Definition Documentation

◆ _WINSOCKAPI_

◆ accept

◆ bind

◆ connect

◆ EACCESS

◆ EADDRINUSE

◆ EADDRNOTAVAIL

◆ EAFNOSUPPORT

◆ EAGAIN

◆ ECONNABORTED

◆ ECONNREFUSED

◆ ECONNRESET

◆ EHOSTUNREACH

◆ EIDRM

◆ EINPROGRESS

◆ EINTR

◆ EISCONN

◆ EMSGSIZE

◆ ENABLE_SSPI

◆ ENOBUFS

◆ ENOTCONN

◆ ENOTSOCK

◆ EOPNOTSUPP

◆ EPROTONOSUPPORT

◆ EWOULDBLOCK

◆ fseeko

◆ fsync

◆ FSYNC_WRITETHROUGH_IS_FSYNC

◆ ftello

◆ ftruncate

◆ GETNCNT

◆ GETPID

◆ GETVAL

◆ HAVE_FSYNC_WRITETHROUGH

◆ HAVE_UNION_SEMUN

◆ IPC_CREAT

◆ IPC_EXCL

◆ IPC_NOWAIT

◆ IPC_PRIVATE

◆ IPC_RMID

◆ IPC_STAT

◆ isalnum_l

◆ isalpha_l

◆ isdigit_l

◆ isgraph_l

◆ islower_l

◆ isprint_l

◆ ispunct_l

◆ isspace_l

◆ isupper_l

◆ iswalnum_l

◆ iswalpha_l

◆ iswdigit_l

◆ iswgraph_l

◆ iswlower_l

◆ iswprint_l

◆ iswpunct_l

◆ iswspace_l

◆ iswupper_l

◆ ITIMER_REAL

◆ kill

◆ listen

◆ locale_t

◆ lstat

◆ mbstowcs_l

◆ mkdir

◆ O_DSYNC

◆ PG_SIGNAL_COUNT

◆ pgoff_t

◆ putenv

◆ readlink

◆ recv

◆ S_IRGRP

◆ S_IROTH