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

Include dependency graph for win32_port.h:

Data Structures
struct	itimerval

struct	stat

Macros
#define	ENABLE_SSPI 1

#define	_WINSOCKAPI_

#define	WIN32_LEAN_AND_MEAN

#define	UMDF_USING_NTSTATUS

#define	fstat microsoft_native_fstat

#define	stat microsoft_native_stat

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

#define	fsync(fd) _commit(fd)

#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	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	fstat(fileno, sb) _pgfstat64(fileno, sb)

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

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

#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	S_IFLNK S_IFCHR

#define	S_ISLNK(m) (((m) & S_IFLNK) == S_IFLNK)

#define	O_DSYNC 0x0080

#define	O_CLOEXEC 0

#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	EHOSTDOWN WSAEHOSTDOWN

#define	EHOSTUNREACH WSAEHOSTUNREACH

#define	ENETDOWN WSAENETDOWN

#define	ENETRESET WSAENETRESET

#define	ENETUNREACH WSAENETUNREACH

#define	ENOTCONN WSAENOTCONN

#define	ETIMEDOUT WSAETIMEDOUT

#define	strtok_r strtok_s

#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	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	RTLD_NOW 1

#define	RTLD_GLOBAL 0

#define	putenv(x) pgwin32_putenv(x)

#define	setenv(x, y, z) pgwin32_setenv(x,y,z)

#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)

DWORD	pgwin32_get_file_type (HANDLE hFile)

int	pgsymlink (const char oldpath, const char newpath)

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

int	_pgfstat64 (int fileno, struct stat *buf)

int	_pgstat64 (const char name, struct stat buf)

int	_pglstat64 (const char name, 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 *	dlopen (const char *file, int mode)

void *	dlsym (void handle, const char symbol)

int	dlclose (void *handle)

char *	dlerror (void)

void	_dosmaperr (unsigned long)

int	pgwin32_putenv (const char *)

int	pgwin32_setenv (const char name, const char value, int overwrite)

int	pgwin32_unsetenv (const char *name)

int	pgwin32_is_service (void)

int	pgwin32_is_admin (void)

BOOL	AddUserToTokenDacl (HANDLE hToken)

ssize_t	pg_pread (int fd, void *buf, size_t nbyte, pgoff_t offset)

ssize_t	pg_pwrite (int fd, const void *buf, size_t nbyte, pgoff_t offset)

Variables
PGDLLIMPORT volatile int	pg_signal_queue

PGDLLIMPORT int	pg_signal_mask

PGDLLIMPORT HANDLE	pgwin32_signal_event

PGDLLIMPORT HANDLE	pgwin32_initial_signal_pipe

PGDLLIMPORT 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 501 of file win32_port.h.

◆ bind

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

Definition at line 499 of file win32_port.h.

◆ connect

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

Definition at line 502 of file win32_port.h.

◆ EACCESS

#define EACCESS 2048

Definition at line 100 of file win32_port.h.

◆ EADDRINUSE

#define EADDRINUSE WSAEADDRINUSE

Definition at line 390 of file win32_port.h.

◆ EADDRNOTAVAIL

#define EADDRNOTAVAIL WSAEADDRNOTAVAIL

Definition at line 392 of file win32_port.h.

◆ EAFNOSUPPORT

#define EAFNOSUPPORT WSAEAFNOSUPPORT

Definition at line 368 of file win32_port.h.

◆ EAGAIN

#define EAGAIN WSAEWOULDBLOCK

Definition at line 362 of file win32_port.h.

◆ ECONNABORTED

#define ECONNABORTED WSAECONNABORTED

Definition at line 372 of file win32_port.h.

◆ ECONNREFUSED

#define ECONNREFUSED WSAECONNREFUSED

Definition at line 384 of file win32_port.h.

◆ ECONNRESET

#define ECONNRESET WSAECONNRESET

Definition at line 374 of file win32_port.h.

◆ EHOSTDOWN

#define EHOSTDOWN WSAEHOSTDOWN

Definition at line 394 of file win32_port.h.

◆ EHOSTUNREACH

#define EHOSTUNREACH WSAEHOSTUNREACH

Definition at line 396 of file win32_port.h.

◆ EIDRM

#define EIDRM 4096

Definition at line 102 of file win32_port.h.

◆ EINPROGRESS

#define EINPROGRESS WSAEINPROGRESS

Definition at line 376 of file win32_port.h.

◆ EINTR

#define EINTR WSAEINTR

Definition at line 364 of file win32_port.h.

◆ EISCONN

#define EISCONN WSAEISCONN

Definition at line 378 of file win32_port.h.

◆ EMSGSIZE

#define EMSGSIZE WSAEMSGSIZE

Definition at line 366 of file win32_port.h.

◆ ENABLE_SSPI

#define ENABLE_SSPI 1

Definition at line 23 of file win32_port.h.

◆ ENETDOWN

#define ENETDOWN WSAENETDOWN

Definition at line 398 of file win32_port.h.

◆ ENETRESET

#define ENETRESET WSAENETRESET

Definition at line 400 of file win32_port.h.

◆ ENETUNREACH

#define ENETUNREACH WSAENETUNREACH

Definition at line 402 of file win32_port.h.

◆ ENOBUFS

#define ENOBUFS WSAENOBUFS

Definition at line 380 of file win32_port.h.

◆ ENOTCONN

#define ENOTCONN WSAENOTCONN

Definition at line 404 of file win32_port.h.

◆ ENOTSOCK

#define ENOTSOCK WSAENOTSOCK

Definition at line 386 of file win32_port.h.

◆ EOPNOTSUPP

#define EOPNOTSUPP WSAEOPNOTSUPP

Definition at line 388 of file win32_port.h.

◆ EPROTONOSUPPORT

#define EPROTONOSUPPORT WSAEPROTONOSUPPORT

Definition at line 382 of file win32_port.h.

◆ ETIMEDOUT

#define ETIMEDOUT WSAETIMEDOUT

Definition at line 406 of file win32_port.h.

◆ EWOULDBLOCK

#define EWOULDBLOCK WSAEWOULDBLOCK

Definition at line 370 of file win32_port.h.

◆ fseeko

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

Definition at line 206 of file win32_port.h.

◆ fstat [1/2]

#define fstat microsoft_native_fstat

Definition at line 273 of file win32_port.h.

◆ fstat [2/2]

#define fstat	(	fileno,
		sb
	)	_pgfstat64(fileno, sb)

Definition at line 273 of file win32_port.h.

◆ fsync

#define fsync ( fd ) _commit(fd)

Definition at line 83 of file win32_port.h.

◆ ftello

#define ftello ( stream ) ftello64(stream)

Definition at line 209 of file win32_port.h.

◆ GETNCNT

#define GETNCNT 16384

Definition at line 106 of file win32_port.h.

◆ GETPID

#define GETPID 262144

Definition at line 109 of file win32_port.h.

◆ GETVAL

#define GETVAL 65536

Definition at line 107 of file win32_port.h.

◆ HAVE_UNION_SEMUN

#define HAVE_UNION_SEMUN 1

Definition at line 91 of file win32_port.h.

◆ IPC_CREAT

#define IPC_CREAT 512

Definition at line 94 of file win32_port.h.

◆ IPC_EXCL

#define IPC_EXCL 1024

Definition at line 95 of file win32_port.h.

◆ IPC_NOWAIT

#define IPC_NOWAIT 2048

Definition at line 97 of file win32_port.h.

◆ IPC_PRIVATE

#define IPC_PRIVATE 234564

Definition at line 96 of file win32_port.h.

◆ IPC_RMID

#define IPC_RMID 256

Definition at line 93 of file win32_port.h.

◆ IPC_STAT

#define IPC_STAT 4096

Definition at line 98 of file win32_port.h.

◆ isalnum_l

#define isalnum_l _isalnum_l

Definition at line 441 of file win32_port.h.

◆ isalpha_l

#define isalpha_l _isalpha_l

Definition at line 439 of file win32_port.h.

◆ isdigit_l

#define isdigit_l _isdigit_l

Definition at line 437 of file win32_port.h.

◆ isgraph_l

#define isgraph_l _isgraph_l

Definition at line 447 of file win32_port.h.

◆ islower_l

#define islower_l _islower_l

Definition at line 445 of file win32_port.h.

◆ isprint_l

#define isprint_l _isprint_l

Definition at line 449 of file win32_port.h.

◆ ispunct_l

#define ispunct_l _ispunct_l

Definition at line 451 of file win32_port.h.

◆ isspace_l

#define isspace_l _isspace_l

Definition at line 453 of file win32_port.h.

◆ isupper_l

#define isupper_l _isupper_l

Definition at line 443 of file win32_port.h.

◆ iswalnum_l

#define iswalnum_l _iswalnum_l

Definition at line 442 of file win32_port.h.

◆ iswalpha_l

#define iswalpha_l _iswalpha_l

Definition at line 440 of file win32_port.h.

◆ iswdigit_l

#define iswdigit_l _iswdigit_l

Definition at line 438 of file win32_port.h.

◆ iswgraph_l

#define iswgraph_l _iswgraph_l

Definition at line 448 of file win32_port.h.

◆ iswlower_l

#define iswlower_l _iswlower_l

Definition at line 446 of file win32_port.h.

◆ iswprint_l

#define iswprint_l _iswprint_l

Definition at line 450 of file win32_port.h.

◆ iswpunct_l

#define iswpunct_l _iswpunct_l

Definition at line 452 of file win32_port.h.

◆ iswspace_l

#define iswspace_l _iswspace_l

Definition at line 454 of file win32_port.h.

◆ iswupper_l

#define iswupper_l _iswupper_l

Definition at line 444 of file win32_port.h.

◆ ITIMER_REAL

#define ITIMER_REAL 0

Definition at line 180 of file win32_port.h.

◆ kill

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

Definition at line 493 of file win32_port.h.

◆ listen

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

Definition at line 500 of file win32_port.h.

◆ locale_t

#define locale_t _locale_t

Definition at line 432 of file win32_port.h.

◆ lstat

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

Definition at line 275 of file win32_port.h.

◆ mkdir

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

Definition at line 80 of file win32_port.h.

◆ O_CLOEXEC

#define O_CLOEXEC 0

Definition at line 349 of file win32_port.h.

◆ O_DSYNC

#define O_DSYNC 0x0080

Definition at line 342 of file win32_port.h.

◆ PG_SIGNAL_COUNT

#define PG_SIGNAL_COUNT 32

Definition at line 485 of file win32_port.h.

◆ pgoff_t

#define pgoff_t __int64

Definition at line 197 of file win32_port.h.

◆ putenv

#define putenv ( x ) pgwin32_putenv(x)

Definition at line 544 of file win32_port.h.

◆ readlink

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

Definition at line 226 of file win32_port.h.

◆ recv

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

Definition at line 504 of file win32_port.h.

◆ RTLD_GLOBAL

#define RTLD_GLOBAL 0

Definition at line 534 of file win32_port.h.

◆ RTLD_NOW

#define RTLD_NOW 1

Definition at line 533 of file win32_port.h.

◆ S_IFLNK

#define S_IFLNK S_IFCHR

Definition at line 333 of file win32_port.h.

◆ S_IRGRP

#define S_IRGRP 0

Definition at line 291 of file win32_port.h.

◆ S_IROTH

#define S_IROTH 0

Definition at line 303 of file win32_port.h.

◆ S_IRUSR

#define S_IRUSR _S_IREAD

Definition at line 279 of file win32_port.h.

◆ S_IRWXG

#define S_IRWXG 0

Definition at line 300 of file win32_port.h.

◆ S_IRWXO

#define S_IRWXO 0

Definition at line 312 of file win32_port.h.

◆ S_IRWXU

#define S_IRWXU (S_IRUSR | S_IWUSR | S_IXUSR)

Definition at line 288 of file win32_port.h.

◆ S_ISDIR

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

Definition at line 315 of file win32_port.h.

◆ S_ISLNK

#define S_ISLNK ( m ) (((m) & S_IFLNK) == S_IFLNK)

Definition at line 334 of file win32_port.h.

◆ S_ISREG

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

Definition at line 318 of file win32_port.h.

◆ S_IWGRP

#define S_IWGRP 0

Definition at line 294 of file win32_port.h.

◆ S_IWOTH

#define S_IWOTH 0

Definition at line 306 of file win32_port.h.

◆ S_IWUSR

#define S_IWUSR _S_IWRITE

Definition at line 282 of file win32_port.h.

◆ S_IXGRP

#define S_IXGRP 0

Definition at line 297 of file win32_port.h.

◆ S_IXOTH

#define S_IXOTH 0

Definition at line 309 of file win32_port.h.

◆ S_IXUSR

#define S_IXUSR _S_IEXEC

Definition at line 285 of file win32_port.h.

◆ select

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

Definition at line 503 of file win32_port.h.

◆ send

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

Definition at line 505 of file win32_port.h.

◆ SETALL

#define SETALL 8192

Definition at line 105 of file win32_port.h.

◆ setenv

#define setenv	(	x,
		y,
		z
	)	pgwin32_setenv(x,y,z)

Definition at line 545 of file win32_port.h.

◆ setlocale

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

Definition at line 475 of file win32_port.h.

◆ SETVAL

#define SETVAL 131072

Definition at line 108 of file win32_port.h.

◆ SIGABRT

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

Definition at line 161 of file win32_port.h.

◆ SIGALRM

#define SIGALRM 14

Definition at line 164 of file win32_port.h.

◆ SIGCHLD

#define SIGCHLD 20

Definition at line 168 of file win32_port.h.

◆ SIGCONT

#define SIGCONT 19

Definition at line 167 of file win32_port.h.

◆ SIGHUP

#define SIGHUP 1

Definition at line 158 of file win32_port.h.

◆ SIGKILL

#define SIGKILL 9

Definition at line 162 of file win32_port.h.

◆ sigmask

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

Definition at line 155 of file win32_port.h.

◆ SIGPIPE

#define SIGPIPE 13

Definition at line 163 of file win32_port.h.

◆ SIGQUIT

#define SIGQUIT 3

Definition at line 159 of file win32_port.h.

◆ SIGSTOP

#define SIGSTOP 17

Definition at line 165 of file win32_port.h.

◆ SIGTRAP

#define SIGTRAP 5

Definition at line 160 of file win32_port.h.

◆ SIGTSTP

#define SIGTSTP 18

Definition at line 166 of file win32_port.h.

◆ SIGUSR1

#define SIGUSR1 30

Definition at line 170 of file win32_port.h.

◆ SIGUSR2

#define SIGUSR2 31

Definition at line 171 of file win32_port.h.

◆ SIGWINCH

#define SIGWINCH 28

Definition at line 169 of file win32_port.h.

◆ socket

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

Definition at line 498 of file win32_port.h.

◆ stat [1/2]

#define stat microsoft_native_stat

Definition at line 274 of file win32_port.h.

◆ stat [2/2]

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

Definition at line 274 of file win32_port.h.

◆ strcoll_l

#define strcoll_l _strcoll_l

Definition at line 455 of file win32_port.h.

◆ strtok_r

#define strtok_r strtok_s

Definition at line 411 of file win32_port.h.

◆ strxfrm_l

#define strxfrm_l _strxfrm_l

Definition at line 456 of file win32_port.h.

◆ symlink

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

Definition at line 225 of file win32_port.h.

◆ tolower_l

#define tolower_l _tolower_l

Definition at line 433 of file win32_port.h.

◆ toupper_l

#define toupper_l _toupper_l

Definition at line 434 of file win32_port.h.

◆ towlower_l

#define towlower_l _towlower_l

Definition at line 435 of file win32_port.h.

◆ towupper_l

#define towupper_l _towupper_l

Definition at line 436 of file win32_port.h.

◆ UMDF_USING_NTSTATUS

#define UMDF_USING_NTSTATUS

Definition at line 58 of file win32_port.h.

◆ UNBLOCKED_SIGNAL_QUEUE

#define UNBLOCKED_SIGNAL_QUEUE ( ) (pg_signal_queue & ~pg_signal_mask)

Definition at line 484 of file win32_port.h.

◆ unsetenv

#define unsetenv ( x ) pgwin32_unsetenv(x)

Definition at line 546 of file win32_port.h.

◆ USES_WINSOCK

#define USES_WINSOCK

Definition at line 85 of file win32_port.h.

◆ wcscoll_l

#define wcscoll_l _wcscoll_l

Definition at line 457 of file win32_port.h.

◆ WEXITSTATUS

#define WEXITSTATUS ( w ) (w)

Definition at line 152 of file win32_port.h.

◆ WIFEXITED

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

Definition at line 150 of file win32_port.h.

◆ WIFSIGNALED

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

Definition at line 151 of file win32_port.h.

◆ WIN32_LEAN_AND_MEAN

#define WIN32_LEAN_AND_MEAN

Definition at line 57 of file win32_port.h.

◆ WTERMSIG

#define WTERMSIG ( w ) (w)

Definition at line 153 of file win32_port.h.

Typedef Documentation

◆ gid_t

typedef int gid_t

Definition at line 235 of file win32_port.h.

◆ key_t

typedef long key_t

Definition at line 237 of file win32_port.h.

◆ uid_t

typedef int uid_t

Definition at line 234 of file win32_port.h.

Function Documentation

◆ _dosmaperr()

void _dosmaperr ( unsigned long e )

Definition at line 177 of file win32error.c.

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

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

Referenced by BaseBackup(), cache_locale_time(), copyFile(), dsm_impl_pin_segment(), dsm_impl_unpin_segment(), fdatasync(), fileinfo_to_stat(), FileReadV(), FileWriteV(), getrusage(), initialize_ntdll(), link(), pg_import_system_collations(), pg_pread(), pg_pwrite(), pgwin32_get_file_type(), and readdir().

◆ _pgfstat64()

int _pgfstat64	(	int	fileno,
		struct stat *	buf
	)

Definition at line 255 of file win32stat.c.

{
    HANDLE      hFile = (HANDLE) _get_osfhandle(fileno);
    DWORD       fileType = FILE_TYPE_UNKNOWN;
    unsigned short st_mode;
 
    if (buf == NULL)
    {
        errno = EINVAL;
        return -1;
    }
 
    fileType = pgwin32_get_file_type(hFile);
    if (errno != 0)
        return -1;
 
    switch (fileType)
    {
            /* The specified file is a disk file */
        case FILE_TYPE_DISK:
            return fileinfo_to_stat(hFile, buf);
 
            /*
             * The specified file is a socket, a named pipe, or an anonymous
             * pipe.
             */
        case FILE_TYPE_PIPE:
            st_mode = _S_IFIFO;
            break;
            /* The specified file is a character file */
        case FILE_TYPE_CHAR:
            st_mode = _S_IFCHR;
            break;
            /* Unused flag and unknown file type */
        case FILE_TYPE_REMOTE:
        case FILE_TYPE_UNKNOWN:
        default:
            errno = EINVAL;
            return -1;
    }
 
    memset(buf, 0, sizeof(*buf));
    buf->st_mode = st_mode;
    buf->st_dev = fileno;
    buf->st_rdev = fileno;
    buf->st_nlink = 1;
    return 0;
}

References buf, fileinfo_to_stat(), and pgwin32_get_file_type().

◆ _pglstat64()

int _pglstat64	(	const char *	name,
		struct stat *	buf
	)

Definition at line 113 of file win32stat.c.

{
    /*
     * Our open wrapper will report STATUS_DELETE_PENDING as ENOENT.  We
     * request FILE_FLAG_BACKUP_SEMANTICS so that we can open directories too,
     * for limited purposes.  We use the private handle-based version, so we
     * don't risk running out of fds.
     */
    HANDLE      hFile;
    int         ret;
 
    hFile = pgwin32_open_handle(name, O_RDONLY, true);
    if (hFile == INVALID_HANDLE_VALUE)
    {
        if (errno == ENOENT)
        {
            /*
             * If it's a junction point pointing to a non-existent path, we'll
             * have ENOENT here (because pgwin32_open_handle does not use
             * FILE_FLAG_OPEN_REPARSE_POINT).  In that case, we'll try again
             * with readlink() below, which will distinguish true ENOENT from
             * pseudo-symlink.
             */
            memset(buf, 0, sizeof(*buf));
            ret = 0;
        }
        else
            return -1;
    }
    else
        ret = fileinfo_to_stat(hFile, buf);
 
    /*
     * Junction points appear as directories to fileinfo_to_stat(), so we'll
     * need to do a bit more work to distinguish them.
     */
    if ((ret == 0 && S_ISDIR(buf->st_mode)) || hFile == INVALID_HANDLE_VALUE)
    {
        char        next[MAXPGPATH];
        ssize_t     size;
 
        /*
         * POSIX says we need to put the length of the target path into
         * st_size.  Use readlink() to get it, or learn that this is not a
         * junction point.
         */
        size = readlink(name, next, sizeof(next));
        if (size < 0)
        {
            if (errno == EACCES &&
                pg_RtlGetLastNtStatus() == STATUS_DELETE_PENDING)
            {
                /* Unlinked underneath us. */
                errno = ENOENT;
                ret = -1;
            }
            else if (errno == EINVAL)
            {
                /* It's not a junction point, nothing to do. */
            }
            else
            {
                /* Some other failure. */
                ret = -1;
            }
        }
        else
        {
            /* It's a junction point, so report it as a symlink. */
            buf->st_mode &= ~S_IFDIR;
            buf->st_mode |= S_IFLNK;
            buf->st_size = size;
            ret = 0;
        }
    }
 
    if (hFile != INVALID_HANDLE_VALUE)
        CloseHandle(hFile);
    return ret;
}

References buf, fileinfo_to_stat(), MAXPGPATH, name, next, pg_RtlGetLastNtStatus, readlink, S_IFLNK, and S_ISDIR.

Referenced by _pgstat64().

◆ _pgstat64()

int _pgstat64	(	const char *	name,
		struct stat *	buf
	)

Definition at line 198 of file win32stat.c.

{
    int         loops = 0;
    int         ret;
    char        curr[MAXPGPATH];
 
    ret = _pglstat64(name, buf);
 
    strlcpy(curr, name, MAXPGPATH);
 
    /* Do we need to follow a symlink (junction point)? */
    while (ret == 0 && S_ISLNK(buf->st_mode))
    {
        char        next[MAXPGPATH];
        ssize_t     size;
 
        if (++loops > 8)
        {
            errno = ELOOP;
            return -1;
        }
 
        /*
         * _pglstat64() already called readlink() once to be able to fill in
         * st_size, and now we need to do it again to get the path to follow.
         * That could be optimized, but stat() on symlinks is probably rare
         * and this way is simple.
         */
        size = readlink(curr, next, sizeof(next));
        if (size < 0)
        {
            if (errno == EACCES &&
                pg_RtlGetLastNtStatus() == STATUS_DELETE_PENDING)
            {
                /* Unlinked underneath us. */
                errno = ENOENT;
            }
            return -1;
        }
        if (size >= sizeof(next))
        {
            errno = ENAMETOOLONG;
            return -1;
        }
        next[size] = 0;
 
        ret = _pglstat64(next, buf);
        strcpy(curr, next);
    }
 
    return ret;
}

References _pglstat64(), buf, MAXPGPATH, name, next, pg_RtlGetLastNtStatus, readlink, S_ISLNK, and strlcpy().

◆ AddUserToTokenDacl()

BOOL AddUserToTokenDacl ( HANDLE hToken )

◆ dlclose()

int dlclose ( void * handle )

Definition at line 49 of file win32dlopen.c.

{
    if (!FreeLibrary((HMODULE) handle))
    {
        set_dl_error();
        return 1;
    }
    last_dyn_error[0] = 0;
    return 0;
}

References last_dyn_error, and set_dl_error().

Referenced by internal_load_library().

◆ dlerror()

char * dlerror ( void )

Definition at line 40 of file win32dlopen.c.

{
    if (last_dyn_error[0])
        return last_dyn_error;
    else
        return NULL;
}

References last_dyn_error.

Referenced by internal_load_library().

◆ dlopen()

void * dlopen	(	const char *	file,
		int	mode
	)

Definition at line 76 of file win32dlopen.c.

{
    HMODULE     h;
    int         prevmode;
 
    /* Disable popup error messages when loading DLLs */
    prevmode = SetErrorMode(SEM_FAILCRITICALERRORS | SEM_NOOPENFILEERRORBOX);
    h = LoadLibrary(file);
    SetErrorMode(prevmode);
 
    if (!h)
    {
        set_dl_error();
        return NULL;
    }
    last_dyn_error[0] = 0;
    return (void *) h;
}

References last_dyn_error, and set_dl_error().

Referenced by internal_load_library().

◆ dlsym()

void * dlsym	(	void *	handle,
		const char *	symbol
	)

Definition at line 61 of file win32dlopen.c.

{
    void       *ptr;
 
    ptr = GetProcAddress((HMODULE) handle, symbol);
    if (!ptr)
    {
        set_dl_error();
        return NULL;
    }
    last_dyn_error[0] = 0;
    return ptr;
}

References last_dyn_error, and set_dl_error().

Referenced by internal_load_library(), load_external_function(), and lookup_external_function().

◆ pg_pread()

ssize_t pg_pread	(	int	fd,
		void *	buf,
		size_t	nbyte,
		pgoff_t	offset
	)

Definition at line 20 of file win32pread.c.

{
    OVERLAPPED  overlapped = {0};
    HANDLE      handle;
    DWORD       result;
 
    handle = (HANDLE) _get_osfhandle(fd);
    if (handle == INVALID_HANDLE_VALUE)
    {
        errno = EBADF;
        return -1;
    }
 
    /* Avoid overflowing DWORD. */
    size = Min(size, 1024 * 1024 * 1024);
 
    /* Note that this changes the file position, despite not using it. */
    overlapped.Offset = (DWORD) offset;
    overlapped.OffsetHigh = (DWORD) (offset >> 32);
 
    if (!ReadFile(handle, buf, size, &result, &overlapped))
    {
        if (GetLastError() == ERROR_HANDLE_EOF)
            return 0;
 
        _dosmaperr(GetLastError());
        return -1;
    }
 
    return result;
}

References _dosmaperr(), buf, fd(), and Min.

◆ pg_pwrite()

ssize_t pg_pwrite	(	int	fd,
		const void *	buf,
		size_t	nbyte,
		pgoff_t	offset
	)

Definition at line 20 of file win32pwrite.c.

{
    OVERLAPPED  overlapped = {0};
    HANDLE      handle;
    DWORD       result;
 
    handle = (HANDLE) _get_osfhandle(fd);
    if (handle == INVALID_HANDLE_VALUE)
    {
        errno = EBADF;
        return -1;
    }
 
    /* Avoid overflowing DWORD. */
    size = Min(size, 1024 * 1024 * 1024);
 
    /* Note that this changes the file position, despite not using it. */
    overlapped.Offset = (DWORD) offset;
    overlapped.OffsetHigh = (DWORD) (offset >> 32);
 
    if (!WriteFile(handle, buf, size, &result, &overlapped))
    {
        _dosmaperr(GetLastError());
        return -1;
    }
 
    return result;
}

References _dosmaperr(), buf, fd(), and Min.

◆ pg_queue_signal()

void pg_queue_signal ( int signum )

Definition at line 259 of file signal.c.

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

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(), and pg_timer_thread().

◆ 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 337 of file socket.c.

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

References pgwin32_poll_signals(), and TranslateSocketError().

◆ pgwin32_bind()

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

Definition at line 315 of file socket.c.

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

References bind, and TranslateSocketError().

◆ pgwin32_connect()

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

Definition at line 359 of file socket.c.

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

References pgwin32_waitforsinglesocket(), and TranslateSocketError().

◆ pgwin32_create_signal_listener()

HANDLE pgwin32_create_signal_listener ( pid_t pid )

Definition at line 227 of file signal.c.

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

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

◆ pgwin32_dispatch_queued_signals()

void pgwin32_dispatch_queued_signals ( void )

Definition at line 120 of file signal.c.

{
    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 */
                struct sigaction *act = &pg_signal_array[i];
                pqsigfunc   sig = act->sa_handler;
 
                if (sig == SIG_DFL)
                    sig = pg_signal_defaults[i];
                pg_signal_queue &= ~sigmask(i);
                if (sig != SIG_ERR && sig != SIG_IGN && sig != SIG_DFL)
                {
                    sigset_t    block_mask;
                    sigset_t    save_mask;
 
                    LeaveCriticalSection(&pg_signal_crit_sec);
 
                    block_mask = act->sa_mask;
                    if ((act->sa_flags & SA_NODEFER) == 0)
                        block_mask |= sigmask(i);
 
                    sigprocmask(SIG_BLOCK, &block_mask, &save_mask);
                    sig(i);
                    sigprocmask(SIG_SETMASK, &save_mask, NULL);
 
                    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);
}

References Assert(), i, pg_signal_array, PG_SIGNAL_COUNT, pg_signal_crit_sec, pg_signal_defaults, pg_signal_queue, pgwin32_signal_event, sig, sigmask, and UNBLOCKED_SIGNAL_QUEUE.

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

◆ pgwin32_get_file_type()

DWORD pgwin32_get_file_type ( HANDLE hFile )

Definition at line 31 of file win32common.c.

{
    DWORD       fileType = FILE_TYPE_UNKNOWN;
    DWORD       lastError;
 
    errno = 0;
 
    /*
     * When stdin, stdout, and stderr aren't associated with a stream the
     * special value -2 is returned:
     * https://learn.microsoft.com/en-us/cpp/c-runtime-library/reference/get-osfhandle
     */
    if (hFile == INVALID_HANDLE_VALUE || hFile == (HANDLE) -2)
    {
        errno = EINVAL;
        return FILE_TYPE_UNKNOWN;
    }
 
    fileType = GetFileType(hFile);
    lastError = GetLastError();
 
    /*
     * Invoke GetLastError in order to distinguish between a "valid" return of
     * FILE_TYPE_UNKNOWN and its return due to a calling error.  In case of
     * success, GetLastError() returns NO_ERROR.
     */
    if (fileType == FILE_TYPE_UNKNOWN && lastError != NO_ERROR)
    {
        _dosmaperr(lastError);
        return FILE_TYPE_UNKNOWN;
    }
 
    return fileType;
}

References _dosmaperr().

Referenced by _pgfstat64().

◆ pgwin32_install_crashdump_handler()

void pgwin32_install_crashdump_handler ( void )

Definition at line 178 of file crashdump.c.

{
    SetUnhandledExceptionFilter(crashDumpHandler);
}

References crashDumpHandler().

Referenced by main().

◆ pgwin32_is_admin()

int pgwin32_is_admin ( void )

Definition at line 49 of file win32security.c.

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

References _, and log_error().

Referenced by check_root().

◆ pgwin32_is_service()

int pgwin32_is_service ( void )

Definition at line 120 of file win32security.c.

{
    static int  _is_service = -1;
    BOOL        IsMember;
    PSID        ServiceSid;
    PSID        LocalSystemSid;
    SID_IDENTIFIER_AUTHORITY NtAuthority = {SECURITY_NT_AUTHORITY};
    HANDLE      stderr_handle;
 
    /* Only check the first time */
    if (_is_service != -1)
        return _is_service;
 
    /* Check if standard error is not valid */
    stderr_handle = GetStdHandle(STD_ERROR_HANDLE);
    if (stderr_handle != INVALID_HANDLE_VALUE && stderr_handle != NULL)
    {
        _is_service = 0;
        return _is_service;
    }
 
    /* Check if running as 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;
}

References fprintf.

Referenced by send_message_to_server_log(), vwrite_stderr(), and write_stderr().

◆ pgwin32_listen()

int pgwin32_listen	(	SOCKET	s,
		int	backlog
	)

Definition at line 326 of file socket.c.

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

References listen, and TranslateSocketError().

◆ pgwin32_putenv()

int pgwin32_putenv ( const char * envval )

Definition at line 27 of file win32env.c.

{
    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 (*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) (pg_funcptr_t) 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);
}

References free, and i.

Referenced by pgwin32_setenv(), and pgwin32_unsetenv().

◆ pgwin32_recv()

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

Definition at line 382 of file socket.c.

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

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

◆ pgwin32_ReserveSharedMemoryRegion()

int pgwin32_ReserveSharedMemoryRegion ( HANDLE hChild )

Definition at line 573 of file win32_shmem.c.

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

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

◆ pgwin32_select()

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

Definition at line 517 of file socket.c.

{
    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 %d",
                     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;
}

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

◆ pgwin32_send()

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

Definition at line 459 of file socket.c.

{
    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 */
 
        if (pgwin32_waitforsinglesocket(s, FD_WRITE | FD_CLOSE, INFINITE) == 0)
            return -1;
    }
 
    return -1;
}

References b, buf, EWOULDBLOCK, len, pgwin32_noblock, pgwin32_poll_signals(), pgwin32_waitforsinglesocket(), and TranslateSocketError().

◆ pgwin32_setenv()

int pgwin32_setenv	(	const char *	name,
		const char *	value,
		int	overwrite
	)

Definition at line 121 of file win32env.c.

{
    int         res;
    char       *envstr;
 
    /* Error conditions, per POSIX */
    if (name == NULL || name[0] == '\0' || strchr(name, '=') != NULL ||
        value == NULL)
    {
        errno = EINVAL;
        return -1;
    }
 
    /* No work if variable exists and we're not to replace it */
    if (overwrite == 0 && getenv(name) != NULL)
        return 0;
 
    envstr = (char *) malloc(strlen(name) + strlen(value) + 2);
    if (!envstr)                /* not much we can do if no memory */
        return -1;
 
    sprintf(envstr, "%s=%s", name, value);
 
    res = pgwin32_putenv(envstr);
    free(envstr);
    return res;
}

References free, malloc, name, overwrite(), pgwin32_putenv(), sprintf, and value.

◆ pgwin32_setlocale()

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

Definition at line 172 of file win32setlocale.c.

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

References locale, locale_map_argument, locale_map_result, map_locale(), setlocale, and unconstify.

◆ pgwin32_signal_initialize()

void pgwin32_signal_initialize ( void )

Definition at line 79 of file signal.c.

{
    int         i;
    HANDLE      signal_thread_handle;
 
    InitializeCriticalSection(&pg_signal_crit_sec);
 
    for (i = 0; i < PG_SIGNAL_COUNT; i++)
    {
        pg_signal_array[i].sa_handler = SIG_DFL;
        pg_signal_array[i].sa_mask = 0;
        pg_signal_array[i].sa_flags = 0;
        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")));
}

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(), and pgwin32_signal_event.

Referenced by InitPostmasterChild(), InitStandaloneProcess(), and PostmasterMain().

◆ pgwin32_socket()

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

Definition at line 291 of file socket.c.

{
    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();
        closesocket(s);
        return INVALID_SOCKET;
    }
    errno = 0;
 
    return s;
}

References closesocket, TranslateSocketError(), and type.

◆ pgwin32_unsetenv()

int pgwin32_unsetenv ( const char * name )

Definition at line 150 of file win32env.c.

{
    int         res;
    char       *envbuf;
 
    /* Error conditions, per POSIX */
    if (name == NULL || name[0] == '\0' || strchr(name, '=') != NULL)
    {
        errno = EINVAL;
        return -1;
    }
 
    envbuf = (char *) malloc(strlen(name) + 2);
    if (!envbuf)
        return -1;
 
    sprintf(envbuf, "%s=", name);
    res = pgwin32_putenv(envbuf);
    free(envbuf);
    return res;
}

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

◆ pgwin32_waitforsinglesocket()

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

Definition at line 181 of file socket.c.

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

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().

◆ setitimer()

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

Definition at line 86 of file timer.c.

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

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

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

Variable Documentation

◆ pg_signal_mask

PGDLLIMPORT int pg_signal_mask

extern

Definition at line 25 of file signal.c.

Referenced by pgwin32_signal_initialize(), and pqsigprocmask().

◆ pg_signal_queue

PGDLLIMPORT volatile int pg_signal_queue

extern

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

PGDLLIMPORT HANDLE pgwin32_initial_signal_pipe

extern

Definition at line 28 of file signal.c.

Referenced by pg_signal_thread().

◆ pgwin32_noblock

PGDLLIMPORT int pgwin32_noblock

extern

Definition at line 28 of file socket.c.

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

◆ pgwin32_signal_event

PGDLLIMPORT HANDLE pgwin32_signal_event

extern

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

◆ EHOSTDOWN

◆ EHOSTUNREACH

◆ EIDRM

◆ EINPROGRESS

◆ EINTR

◆ EISCONN

◆ EMSGSIZE

◆ ENABLE_SSPI

◆ ENETDOWN

◆ ENETRESET

◆ ENETUNREACH

◆ ENOBUFS

◆ ENOTCONN

◆ ENOTSOCK

◆ EOPNOTSUPP

◆ EPROTONOSUPPORT

◆ ETIMEDOUT

◆ EWOULDBLOCK

◆ fseeko

◆ fstat [1/2]

◆ fstat [2/2]

◆ fsync

◆ ftello

◆ GETNCNT

◆ GETPID

◆ GETVAL

◆ 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

◆ mkdir

◆ O_CLOEXEC

◆ O_DSYNC

◆ PG_SIGNAL_COUNT

◆ pgoff_t

◆ putenv