PostgreSQL Source Code git master
Loading...
Searching...
No Matches
Data Structures | Macros | Typedefs | Functions | Variables
win32_port.h File Reference
#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:

Go to the source code of this file.

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 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_CLOEXEC   _O_NOINHERIT
 
#define O_DIRECT   0x80000000
 
#define O_DSYNC   0x04000000
 
#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 __int64 pgoff_t
 
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)
 
ssize_t 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 *addr, int addrlen)
 
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 size, pgoff_t offset)
 
ssize_t pg_pwrite (int fd, const void *buf, size_t size, 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 515 of file win32_port.h.

◆ bind

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

Definition at line 513 of file win32_port.h.

◆ connect

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

Definition at line 516 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 404 of file win32_port.h.

◆ EADDRNOTAVAIL

#define EADDRNOTAVAIL   WSAEADDRNOTAVAIL

Definition at line 406 of file win32_port.h.

◆ EAFNOSUPPORT

#define EAFNOSUPPORT   WSAEAFNOSUPPORT

Definition at line 382 of file win32_port.h.

◆ EAGAIN

#define EAGAIN   WSAEWOULDBLOCK

Definition at line 376 of file win32_port.h.

◆ ECONNABORTED

#define ECONNABORTED   WSAECONNABORTED

Definition at line 386 of file win32_port.h.

◆ ECONNREFUSED

#define ECONNREFUSED   WSAECONNREFUSED

Definition at line 398 of file win32_port.h.

◆ ECONNRESET

#define ECONNRESET   WSAECONNRESET

Definition at line 388 of file win32_port.h.

◆ EHOSTDOWN

#define EHOSTDOWN   WSAEHOSTDOWN

Definition at line 408 of file win32_port.h.

◆ EHOSTUNREACH

#define EHOSTUNREACH   WSAEHOSTUNREACH

Definition at line 410 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 390 of file win32_port.h.

◆ EINTR

#define EINTR   WSAEINTR

Definition at line 378 of file win32_port.h.

◆ EISCONN

#define EISCONN   WSAEISCONN

Definition at line 392 of file win32_port.h.

◆ EMSGSIZE

#define EMSGSIZE   WSAEMSGSIZE

Definition at line 380 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 412 of file win32_port.h.

◆ ENETRESET

#define ENETRESET   WSAENETRESET

Definition at line 414 of file win32_port.h.

◆ ENETUNREACH

#define ENETUNREACH   WSAENETUNREACH

Definition at line 416 of file win32_port.h.

◆ ENOBUFS

#define ENOBUFS   WSAENOBUFS

Definition at line 394 of file win32_port.h.

◆ ENOTCONN

#define ENOTCONN   WSAENOTCONN

Definition at line 418 of file win32_port.h.

◆ ENOTSOCK

#define ENOTSOCK   WSAENOTSOCK

Definition at line 400 of file win32_port.h.

◆ EOPNOTSUPP

#define EOPNOTSUPP   WSAEOPNOTSUPP

Definition at line 402 of file win32_port.h.

◆ EPROTONOSUPPORT

#define EPROTONOSUPPORT   WSAEPROTONOSUPPORT

Definition at line 396 of file win32_port.h.

◆ ETIMEDOUT

#define ETIMEDOUT   WSAETIMEDOUT

Definition at line 420 of file win32_port.h.

◆ EWOULDBLOCK

#define EWOULDBLOCK   WSAEWOULDBLOCK

Definition at line 384 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 73 of file win32_port.h.

◆ fstat [2/2]

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

Definition at line 73 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 455 of file win32_port.h.

◆ isalpha_l

#define isalpha_l   _isalpha_l

Definition at line 453 of file win32_port.h.

◆ isdigit_l

#define isdigit_l   _isdigit_l

Definition at line 451 of file win32_port.h.

◆ isgraph_l

#define isgraph_l   _isgraph_l

Definition at line 461 of file win32_port.h.

◆ islower_l

#define islower_l   _islower_l

Definition at line 459 of file win32_port.h.

◆ isprint_l

#define isprint_l   _isprint_l

Definition at line 463 of file win32_port.h.

◆ ispunct_l

#define ispunct_l   _ispunct_l

Definition at line 465 of file win32_port.h.

◆ isspace_l

#define isspace_l   _isspace_l

Definition at line 467 of file win32_port.h.

◆ isupper_l

#define isupper_l   _isupper_l

Definition at line 457 of file win32_port.h.

◆ iswalnum_l

#define iswalnum_l   _iswalnum_l

Definition at line 456 of file win32_port.h.

◆ iswalpha_l

#define iswalpha_l   _iswalpha_l

Definition at line 454 of file win32_port.h.

◆ iswdigit_l

#define iswdigit_l   _iswdigit_l

Definition at line 452 of file win32_port.h.

◆ iswgraph_l

#define iswgraph_l   _iswgraph_l

Definition at line 462 of file win32_port.h.

◆ iswlower_l

#define iswlower_l   _iswlower_l

Definition at line 460 of file win32_port.h.

◆ iswprint_l

#define iswprint_l   _iswprint_l

Definition at line 464 of file win32_port.h.

◆ iswpunct_l

#define iswpunct_l   _iswpunct_l

Definition at line 466 of file win32_port.h.

◆ iswspace_l

#define iswspace_l   _iswspace_l

Definition at line 468 of file win32_port.h.

◆ iswupper_l

#define iswupper_l   _iswupper_l

Definition at line 458 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 507 of file win32_port.h.

◆ listen

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

Definition at line 514 of file win32_port.h.

◆ locale_t

#define locale_t   _locale_t

Definition at line 446 of file win32_port.h.

◆ lstat

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

Definition at line 292 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   _O_NOINHERIT

Definition at line 361 of file win32_port.h.

◆ O_DIRECT

#define O_DIRECT   0x80000000

Definition at line 362 of file win32_port.h.

◆ O_DSYNC

#define O_DSYNC   0x04000000

Definition at line 363 of file win32_port.h.

◆ PG_SIGNAL_COUNT

#define PG_SIGNAL_COUNT   32

Definition at line 499 of file win32_port.h.

◆ putenv

#define putenv (   x)    pgwin32_putenv(x)

Definition at line 558 of file win32_port.h.

◆ readlink

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

Definition at line 243 of file win32_port.h.

◆ recv

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

Definition at line 518 of file win32_port.h.

◆ RTLD_GLOBAL

#define RTLD_GLOBAL   0

Definition at line 548 of file win32_port.h.

◆ RTLD_NOW

#define RTLD_NOW   1

Definition at line 547 of file win32_port.h.

◆ S_IFLNK

#define S_IFLNK   S_IFCHR

Definition at line 350 of file win32_port.h.

◆ S_IRGRP

#define S_IRGRP   0

Definition at line 308 of file win32_port.h.

◆ S_IROTH

#define S_IROTH   0

Definition at line 320 of file win32_port.h.

◆ S_IRUSR

#define S_IRUSR   _S_IREAD

Definition at line 296 of file win32_port.h.

◆ S_IRWXG

#define S_IRWXG   0

Definition at line 317 of file win32_port.h.

◆ S_IRWXO

#define S_IRWXO   0

Definition at line 329 of file win32_port.h.

◆ S_IRWXU

#define S_IRWXU   (S_IRUSR | S_IWUSR | S_IXUSR)

Definition at line 305 of file win32_port.h.

◆ S_ISDIR

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

Definition at line 332 of file win32_port.h.

◆ S_ISLNK

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

Definition at line 351 of file win32_port.h.

◆ S_ISREG

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

Definition at line 335 of file win32_port.h.

◆ S_IWGRP

#define S_IWGRP   0

Definition at line 311 of file win32_port.h.

◆ S_IWOTH

#define S_IWOTH   0

Definition at line 323 of file win32_port.h.

◆ S_IWUSR

#define S_IWUSR   _S_IWRITE

Definition at line 299 of file win32_port.h.

◆ S_IXGRP

#define S_IXGRP   0

Definition at line 314 of file win32_port.h.

◆ S_IXOTH

#define S_IXOTH   0

Definition at line 326 of file win32_port.h.

◆ S_IXUSR

#define S_IXUSR   _S_IEXEC

Definition at line 302 of file win32_port.h.

◆ select

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

Definition at line 517 of file win32_port.h.

◆ send

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

Definition at line 519 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 559 of file win32_port.h.

◆ setlocale

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

Definition at line 489 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 512 of file win32_port.h.

◆ stat [1/2]

#define stat   microsoft_native_stat

Definition at line 74 of file win32_port.h.

◆ stat [2/2]

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

Definition at line 74 of file win32_port.h.

◆ strcoll_l

#define strcoll_l   _strcoll_l

Definition at line 469 of file win32_port.h.

◆ strtok_r

#define strtok_r   strtok_s

Definition at line 425 of file win32_port.h.

◆ strxfrm_l

#define strxfrm_l   _strxfrm_l

Definition at line 470 of file win32_port.h.

◆ symlink

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

Definition at line 242 of file win32_port.h.

◆ tolower_l

#define tolower_l   _tolower_l

Definition at line 447 of file win32_port.h.

◆ toupper_l

#define toupper_l   _toupper_l

Definition at line 448 of file win32_port.h.

◆ towlower_l

#define towlower_l   _towlower_l

Definition at line 449 of file win32_port.h.

◆ towupper_l

#define towupper_l   _towupper_l

Definition at line 450 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 498 of file win32_port.h.

◆ unsetenv

#define unsetenv (   x)    pgwin32_unsetenv(x)

Definition at line 560 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 471 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 252 of file win32_port.h.

◆ key_t

typedef long key_t

Definition at line 254 of file win32_port.h.

◆ pgoff_t

typedef __int64 pgoff_t

Definition at line 197 of file win32_port.h.

◆ uid_t

typedef int uid_t

Definition at line 251 of file win32_port.h.

Function Documentation

◆ _dosmaperr()

void _dosmaperr ( unsigned long  e)
extern

Definition at line 177 of file win32error.c.

178{
179 if (e == 0)
180 {
181 errno = 0;
182 return;
183 }
184
185 for (size_t i = 0; i < lengthof(doserrors); i++)
186 {
187 if (doserrors[i].winerr == e)
188 {
189 int doserr = doserrors[i].doserr;
190
191#ifndef FRONTEND
192 ereport(DEBUG5,
193 (errmsg_internal("mapped win32 error code %lu to %d",
194 e, doserr)));
195#elif defined(FRONTEND_DEBUG)
196 fprintf(stderr, "mapped win32 error code %lu to %d", e, doserr);
197#endif
198 errno = doserr;
199 return;
200 }
201 }
202
203#ifndef FRONTEND
204 ereport(LOG,
205 (errmsg_internal("unrecognized win32 error code: %lu",
206 e)));
207#else
208 fprintf(stderr, "unrecognized win32 error code: %lu", e);
209#endif
210
211 errno = EINVAL;
212}
lengthof
#define lengthof(array)
Definition c.h:932
fprintf
#define fprintf(file, fmt, msg)
Definition cubescan.l:21
LOG
#define LOG
Definition elog.h:32
errmsg_internal
int int errmsg_internal(const char *fmt,...) pg_attribute_printf(1
ereport
#define ereport(elevel,...)
Definition elog.h:152
DEBUG5
#define DEBUG5
Definition elog.h:27
i
int i
Definition isn.c:77
e
e
Definition preproc-init.c:82
fb
static int fb(int x)
Definition preproc-init.c:92
EINVAL
#define EINVAL
Definition private.h:69
doserrors
static const struct @206 doserrors[]
doserr
int doserr
Definition win32error.c:23
winerr
DWORD winerr
Definition win32error.c:22

References DEBUG5, doserr, doserrors, EINVAL, ereport, errmsg_internal(), fb(), 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 
)
extern

Definition at line 260 of file win32stat.c.

261{
262 HANDLE hFile = (HANDLE) _get_osfhandle(fileno);
263 DWORD fileType = FILE_TYPE_UNKNOWN;
264 unsigned short st_mode;
265
266 if (buf == NULL)
267 {
268 errno = EINVAL;
269 return -1;
270 }
271
272 fileType = pgwin32_get_file_type(hFile);
273 if (errno != 0)
274 return -1;
275
276 switch (fileType)
277 {
278 /* The specified file is a disk file */
279 case FILE_TYPE_DISK:
280 return fileinfo_to_stat(hFile, buf);
281
282 /*
283 * The specified file is a socket, a named pipe, or an anonymous
284 * pipe.
285 */
286 case FILE_TYPE_PIPE:
287 st_mode = _S_IFIFO;
288 break;
289 /* The specified file is a character file */
290 case FILE_TYPE_CHAR:
291 st_mode = _S_IFCHR;
292 break;
293 /* Unused flag and unknown file type */
294 case FILE_TYPE_REMOTE:
295 case FILE_TYPE_UNKNOWN:
296 default:
297 errno = EINVAL;
298 return -1;
299 }
300
301 memset(buf, 0, sizeof(*buf));
302 buf->st_mode = st_mode;
303 buf->st_dev = fileno;
304 buf->st_rdev = fileno;
305 buf->st_nlink = 1;
306 return 0;
307}
buf
static char buf[DEFAULT_XLOG_SEG_SIZE]
Definition pg_test_fsync.c:71
pgwin32_get_file_type
DWORD pgwin32_get_file_type(HANDLE hFile)
Definition win32common.c:31
fileinfo_to_stat
static int fileinfo_to_stat(HANDLE hFile, struct stat *buf)
Definition win32stat.c:68

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

◆ _pglstat64()

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

Definition at line 113 of file win32stat.c.

114{
115 /*
116 * Our open wrapper will report STATUS_DELETE_PENDING as ENOENT. We
117 * request FILE_FLAG_BACKUP_SEMANTICS so that we can open directories too,
118 * for limited purposes. We use the private handle-based version, so we
119 * don't risk running out of fds.
120 */
121 HANDLE hFile;
122 int ret;
123
124 hFile = pgwin32_open_handle(name, O_RDONLY, true);
125 if (hFile == INVALID_HANDLE_VALUE)
126 {
127 if (errno == ENOENT)
128 {
129 /*
130 * If it's a junction point pointing to a non-existent path, we'll
131 * have ENOENT here (because pgwin32_open_handle does not use
132 * FILE_FLAG_OPEN_REPARSE_POINT). In that case, we'll try again
133 * with readlink() below, which will distinguish true ENOENT from
134 * pseudo-symlink.
135 */
136 memset(buf, 0, sizeof(*buf));
137 ret = 0;
138 }
139 else
140 return -1;
141 }
142 else
143 ret = fileinfo_to_stat(hFile, buf);
144
145 /*
146 * Junction points appear as directories to fileinfo_to_stat(), so we'll
147 * need to do a bit more work to distinguish them.
148 */
149 if ((ret == 0 && S_ISDIR(buf->st_mode)) || hFile == INVALID_HANDLE_VALUE)
150 {
151 char next[MAXPGPATH];
152 ssize_t size;
153
154 /*
155 * POSIX says we need to put the length of the target path into
156 * st_size. Use readlink() to get it, or learn that this is not a
157 * junction point.
158 */
159 size = readlink(name, next, sizeof(next));
160 if (size < 0)
161 {
162 if (errno == EACCES &&
163 pg_RtlGetLastNtStatus() == STATUS_DELETE_PENDING)
164 {
165 /* Unlinked underneath us. */
166 errno = ENOENT;
167 ret = -1;
168 }
169 else if (errno == EINVAL)
170 {
171 /* It's not a junction point, nothing to do. */
172 }
173 else
174 {
175 /* Some other failure. */
176 ret = -1;
177 }
178 }
179 else if (size >= sizeof(next))
180 {
181 errno = ENAMETOOLONG;
182 ret = -1;
183 }
184 else
185 {
186 /* It's a junction point, so report it as a symlink. */
187 buf->st_mode &= ~S_IFDIR;
188 buf->st_mode |= S_IFLNK;
189 buf->st_size = size;
190 ret = 0;
191 }
192 }
193
194 if (hFile != INVALID_HANDLE_VALUE)
195 CloseHandle(hFile);
196 return ret;
197}
next
static int32 next
Definition blutils.c:225
MAXPGPATH
#define MAXPGPATH
Definition pg_config_manual.h:105
ENAMETOOLONG
#define ENAMETOOLONG
Definition private.h:76
name
const char * name
Definition wait_event_funcs.c:29
S_ISDIR
#define S_ISDIR(m)
Definition win32_port.h:332
readlink
#define readlink(path, buf, size)
Definition win32_port.h:243
S_IFLNK
#define S_IFLNK
Definition win32_port.h:350
pg_RtlGetLastNtStatus
PGDLLIMPORT RtlGetLastNtStatus_t pg_RtlGetLastNtStatus
Definition win32ntdll.c:20

References buf, EINVAL, ENAMETOOLONG, fb(), 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 
)
extern

Definition at line 203 of file win32stat.c.

204{
205 int loops = 0;
206 int ret;
207 char curr[MAXPGPATH];
208
209 ret = _pglstat64(name, buf);
210
211 strlcpy(curr, name, MAXPGPATH);
212
213 /* Do we need to follow a symlink (junction point)? */
214 while (ret == 0 && S_ISLNK(buf->st_mode))
215 {
216 char next[MAXPGPATH];
217 ssize_t size;
218
219 if (++loops > 8)
220 {
221 errno = ELOOP;
222 return -1;
223 }
224
225 /*
226 * _pglstat64() already called readlink() once to be able to fill in
227 * st_size, and now we need to do it again to get the path to follow.
228 * That could be optimized, but stat() on symlinks is probably rare
229 * and this way is simple.
230 */
231 size = readlink(curr, next, sizeof(next));
232 if (size < 0)
233 {
234 if (errno == EACCES &&
235 pg_RtlGetLastNtStatus() == STATUS_DELETE_PENDING)
236 {
237 /* Unlinked underneath us. */
238 errno = ENOENT;
239 }
240 return -1;
241 }
242 else if (size >= sizeof(next))
243 {
244 errno = ENAMETOOLONG;
245 return -1;
246 }
247 next[size] = 0;
248
249 ret = _pglstat64(next, buf);
250 strcpy(curr, next);
251 }
252
253 return ret;
254}
strlcpy
size_t strlcpy(char *dst, const char *src, size_t siz)
Definition strlcpy.c:45
ELOOP
#define ELOOP
Definition private.h:73
S_ISLNK
#define S_ISLNK(m)
Definition win32_port.h:351
_pglstat64
int _pglstat64(const char *name, struct stat *buf)
Definition win32stat.c:113

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

◆ AddUserToTokenDacl()

BOOL AddUserToTokenDacl ( HANDLE  hToken)
extern

◆ dlclose()

int dlclose ( void *  handle)
extern

Definition at line 49 of file win32dlopen.c.

50{
51 if (!FreeLibrary((HMODULE) handle))
52 {
53 set_dl_error();
54 return 1;
55 }
56 last_dyn_error[0] = 0;
57 return 0;
58}
last_dyn_error
static char last_dyn_error[512]
Definition win32dlopen.c:18
set_dl_error
static void set_dl_error(void)
Definition win32dlopen.c:21

References fb(), last_dyn_error, and set_dl_error().

Referenced by internal_load_library().

◆ dlerror()

char * dlerror ( void  )
extern

Definition at line 40 of file win32dlopen.c.

41{
42 if (last_dyn_error[0])
43 return last_dyn_error;
44 else
45 return NULL;
46}

References fb(), and last_dyn_error.

Referenced by internal_load_library().

◆ dlopen()

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

Definition at line 76 of file win32dlopen.c.

77{
78 HMODULE h;
79 int prevmode;
80
81 /* Disable popup error messages when loading DLLs */
82 prevmode = SetErrorMode(SEM_FAILCRITICALERRORS | SEM_NOOPENFILEERRORBOX);
83 h = LoadLibrary(file);
84 SetErrorMode(prevmode);
85
86 if (!h)
87 {
88 set_dl_error();
89 return NULL;
90 }
91 last_dyn_error[0] = 0;
92 return (void *) h;
93}

References fb(), last_dyn_error, and set_dl_error().

Referenced by internal_load_library().

◆ dlsym()

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

Definition at line 61 of file win32dlopen.c.

62{
63 void *ptr;
64
65 ptr = GetProcAddress((HMODULE) handle, symbol);
66 if (!ptr)
67 {
68 set_dl_error();
69 return NULL;
70 }
71 last_dyn_error[0] = 0;
72 return ptr;
73}
symbol
unsigned char symbol
Definition api.h:4

References fb(), 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  size,
pgoff_t  offset 
)
extern

Definition at line 20 of file win32pread.c.

21{
22 OVERLAPPED overlapped = {0};
23 HANDLE handle;
24 DWORD result;
25
26 handle = (HANDLE) _get_osfhandle(fd);
27 if (handle == INVALID_HANDLE_VALUE)
28 {
29 errno = EBADF;
30 return -1;
31 }
32
33 /* Avoid overflowing DWORD. */
34 size = Min(size, 1024 * 1024 * 1024);
35
36 /* Note that this changes the file position, despite not using it. */
37 overlapped.Offset = (DWORD) offset;
38 overlapped.OffsetHigh = (DWORD) (offset >> 32);
39
40 if (!ReadFile(handle, buf, size, &result, &overlapped))
41 {
42 if (GetLastError() == ERROR_HANDLE_EOF)
43 return 0;
44
45 _dosmaperr(GetLastError());
46 return -1;
47 }
48
49 return result;
50}
Min
#define Min(x, y)
Definition c.h:1150
result
uint32 result
Definition checksum_block_internal.h:18
fd
static int fd(const char *x, int i)
Definition preproc-init.c:105
_dosmaperr
void _dosmaperr(unsigned long)
Definition win32error.c:177

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

◆ pg_pwrite()

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

Definition at line 20 of file win32pwrite.c.

21{
22 OVERLAPPED overlapped = {0};
23 HANDLE handle;
24 DWORD result;
25
26 handle = (HANDLE) _get_osfhandle(fd);
27 if (handle == INVALID_HANDLE_VALUE)
28 {
29 errno = EBADF;
30 return -1;
31 }
32
33 /* Avoid overflowing DWORD. */
34 size = Min(size, 1024 * 1024 * 1024);
35
36 /* Note that this changes the file position, despite not using it. */
37 overlapped.Offset = (DWORD) offset;
38 overlapped.OffsetHigh = (DWORD) (offset >> 32);
39
40 if (!WriteFile(handle, buf, size, &result, &overlapped))
41 {
42 _dosmaperr(GetLastError());
43 return -1;
44 }
45
46 return result;
47}

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

◆ pg_queue_signal()

void pg_queue_signal ( int  signum)
extern

Definition at line 263 of file signal.c.

264{
265 Assert(pgwin32_signal_event != NULL);
266 if (signum >= PG_SIGNAL_COUNT || signum <= 0)
267 return; /* ignore any bad signal number */
268
269 EnterCriticalSection(&pg_signal_crit_sec);
270 pg_signal_queue |= sigmask(signum);
271 LeaveCriticalSection(&pg_signal_crit_sec);
272
273 SetEvent(pgwin32_signal_event);
274}
Assert
#define Assert(condition)
Definition c.h:1002
pg_signal_queue
volatile int pg_signal_queue
Definition signal.c:24
pg_signal_crit_sec
static CRITICAL_SECTION pg_signal_crit_sec
Definition signal.c:34
pgwin32_signal_event
HANDLE pgwin32_signal_event
Definition signal.c:27
sigmask
#define sigmask(sig)
Definition win32_port.h:155
PG_SIGNAL_COUNT
#define PG_SIGNAL_COUNT
Definition win32_port.h:499

References Assert, fb(), 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 
)
extern

◆ pgreadlink()

ssize_t pgreadlink ( const char *  path,
char *  buf,
size_t  size 
)
extern

◆ pgsymlink()

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

◆ pgwin32_accept()

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

Definition at line 337 of file socket.c.

338{
339 SOCKET rs;
340
341 /*
342 * Poll for signals, but don't return with EINTR, since we don't handle
343 * that in pqcomm.c
344 */
345 pgwin32_poll_signals();
346
347 rs = WSAAccept(s, addr, addrlen, NULL, 0);
348 if (rs == INVALID_SOCKET)
349 {
350 TranslateSocketError();
351 return INVALID_SOCKET;
352 }
353 return rs;
354}
pgwin32_poll_signals
static int pgwin32_poll_signals(void)
Definition socket.c:157
TranslateSocketError
static void TranslateSocketError(void)
Definition socket.c:56

References fb(), pgwin32_poll_signals(), and TranslateSocketError().

◆ pgwin32_bind()

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

Definition at line 315 of file socket.c.

316{
317 int res;
318
319 res = bind(s, addr, addrlen);
320 if (res < 0)
321 TranslateSocketError();
322 return res;
323}
bind
#define bind(s, addr, addrlen)
Definition win32_port.h:513

References bind, and TranslateSocketError().

◆ pgwin32_connect()

int pgwin32_connect ( SOCKET  s,
const struct sockaddr *  addr,
int  addrlen 
)
extern

Definition at line 359 of file socket.c.

360{
361 int r;
362
363 r = WSAConnect(s, addr, addrlen, NULL, NULL, NULL, NULL);
364 if (r == 0)
365 return 0;
366
367 if (WSAGetLastError() != WSAEWOULDBLOCK)
368 {
369 TranslateSocketError();
370 return -1;
371 }
372
373 while (pgwin32_waitforsinglesocket(s, FD_CONNECT, INFINITE) == 0)
374 {
375 /* Loop endlessly as long as we are just delivering signals */
376 }
377
378 return 0;
379}
pgwin32_waitforsinglesocket
int pgwin32_waitforsinglesocket(SOCKET s, int what, int timeout)
Definition socket.c:181

References fb(), pgwin32_waitforsinglesocket(), and TranslateSocketError().

◆ pgwin32_create_signal_listener()

HANDLE pgwin32_create_signal_listener ( pid_t  pid)
extern

Definition at line 231 of file signal.c.

232{
233 char pipename[128];
234 HANDLE pipe;
235
236 snprintf(pipename, sizeof(pipename), "\\\\.\\pipe\\pgsignal_%u", (int) pid);
237
238 pipe = CreateNamedPipe(pipename, PIPE_ACCESS_DUPLEX,
239 PIPE_TYPE_MESSAGE | PIPE_READMODE_MESSAGE | PIPE_WAIT,
240 PIPE_UNLIMITED_INSTANCES, 16, 16, 1000, NULL);
241
242 if (pipe == INVALID_HANDLE_VALUE)
243 ereport(ERROR,
244 (errmsg("could not create signal listener pipe for PID %d: error code %lu",
245 (int) pid, GetLastError())));
246
247 return pipe;
248}
ERROR
#define ERROR
Definition elog.h:40
errmsg
static char * errmsg
Definition oauth_hook_client.c:61
snprintf
#define snprintf
Definition port.h:261

References ereport, errmsg, ERROR, fb(), pg_signal_info::pid, and snprintf.

◆ pgwin32_dispatch_queued_signals()

void pgwin32_dispatch_queued_signals ( void  )
extern

Definition at line 120 of file signal.c.

121{
122 int exec_mask;
123
124 Assert(pgwin32_signal_event != NULL);
125 EnterCriticalSection(&pg_signal_crit_sec);
126 while ((exec_mask = UNBLOCKED_SIGNAL_QUEUE()) != 0)
127 {
128 /* One or more unblocked signals queued for execution */
129 int i;
130
131 for (i = 1; i < PG_SIGNAL_COUNT; i++)
132 {
133 if (exec_mask & sigmask(i))
134 {
135 /* Execute this signal */
136 struct sigaction *act = &pg_signal_array[i];
137 pqsigfunc sig = (pqsigfunc) (pg_funcptr_t) act->sa_handler;
138
139 if (sig == PG_SIG_DFL)
140 sig = pg_signal_defaults[i];
141 pg_signal_queue &= ~sigmask(i);
142 if (sig != (pqsigfunc) (pg_funcptr_t) SIG_ERR && sig != PG_SIG_IGN && sig != PG_SIG_DFL)
143 {
144 sigset_t block_mask;
145 sigset_t save_mask;
146 struct pg_signal_info nodata;
147
148 nodata.pid = 0;
149 nodata.uid = 0;
150
151 LeaveCriticalSection(&pg_signal_crit_sec);
152
153 block_mask = act->sa_mask;
154 if ((act->sa_flags & SA_NODEFER) == 0)
155 block_mask |= sigmask(i);
156
157 sigprocmask(SIG_BLOCK, &block_mask, &save_mask);
158 sig(i, &nodata);
159 sigprocmask(SIG_SETMASK, &save_mask, NULL);
160
161 EnterCriticalSection(&pg_signal_crit_sec);
162 break; /* Restart outer loop, in case signal mask or
163 * queue has been modified inside signal
164 * handler */
165 }
166 }
167 }
168 }
169 ResetEvent(pgwin32_signal_event);
170 LeaveCriticalSection(&pg_signal_crit_sec);
171}
pg_funcptr_t
void(* pg_funcptr_t)(void)
Definition c.h:607
sig
static int sig
Definition pg_ctl.c:81
pqsigfunc
void(* pqsigfunc)(SIGNAL_ARGS)
Definition port.h:553
PG_SIG_IGN
#define PG_SIG_IGN
Definition port.h:552
PG_SIG_DFL
#define PG_SIG_DFL
Definition port.h:551
pg_signal_array
static struct sigaction pg_signal_array[PG_SIGNAL_COUNT]
Definition signal.c:37
pg_signal_defaults
static pqsigfunc pg_signal_defaults[PG_SIGNAL_COUNT]
Definition signal.c:38
pg_signal_info
Definition c.h:1519
pg_signal_info::pid
uint32_t pid
Definition c.h:1520
UNBLOCKED_SIGNAL_QUEUE
#define UNBLOCKED_SIGNAL_QUEUE()
Definition win32_port.h:498

References Assert, fb(), i, PG_SIG_DFL, PG_SIG_IGN, pg_signal_array, PG_SIGNAL_COUNT, pg_signal_crit_sec, pg_signal_defaults, pg_signal_queue, pgwin32_signal_event, pg_signal_info::pid, 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)
extern

Definition at line 31 of file win32common.c.

32{
33 DWORD fileType = FILE_TYPE_UNKNOWN;
34 DWORD lastError;
35
36 errno = 0;
37
38 /*
39 * When stdin, stdout, and stderr aren't associated with a stream the
40 * special value -2 is returned:
41 * https://learn.microsoft.com/en-us/cpp/c-runtime-library/reference/get-osfhandle
42 */
43 if (hFile == INVALID_HANDLE_VALUE || hFile == (HANDLE) -2)
44 {
45 errno = EINVAL;
46 return FILE_TYPE_UNKNOWN;
47 }
48
49 fileType = GetFileType(hFile);
50 lastError = GetLastError();
51
52 /*
53 * Invoke GetLastError in order to distinguish between a "valid" return of
54 * FILE_TYPE_UNKNOWN and its return due to a calling error. In case of
55 * success, GetLastError() returns NO_ERROR.
56 */
57 if (fileType == FILE_TYPE_UNKNOWN && lastError != NO_ERROR)
58 {
59 _dosmaperr(lastError);
60 return FILE_TYPE_UNKNOWN;
61 }
62
63 return fileType;
64}

References _dosmaperr(), EINVAL, and fb().

Referenced by _pgfstat64().

◆ pgwin32_install_crashdump_handler()

void pgwin32_install_crashdump_handler ( void  )
extern

Definition at line 164 of file crashdump.c.

165{
166 SetUnhandledExceptionFilter(crashDumpHandler);
167}
crashDumpHandler
static LONG WINAPI crashDumpHandler(struct _EXCEPTION_POINTERS *pExceptionInfo)
Definition crashdump.c:76

References crashDumpHandler(), and fb().

Referenced by main().

◆ pgwin32_is_admin()

int pgwin32_is_admin ( void  )
extern

Definition at line 49 of file win32security.c.

50{
51 PSID AdministratorsSid;
52 PSID PowerUsersSid;
53 SID_IDENTIFIER_AUTHORITY NtAuthority = {SECURITY_NT_AUTHORITY};
54 BOOL IsAdministrators;
55 BOOL IsPowerUsers;
56
57 if (!AllocateAndInitializeSid(&NtAuthority, 2,
58 SECURITY_BUILTIN_DOMAIN_RID,
59 DOMAIN_ALIAS_RID_ADMINS, 0, 0, 0, 0, 0,
60 0, &AdministratorsSid))
61 {
62 log_error(_("could not get SID for Administrators group: error code %lu\n"),
63 GetLastError());
64 exit(1);
65 }
66
67 if (!AllocateAndInitializeSid(&NtAuthority, 2,
68 SECURITY_BUILTIN_DOMAIN_RID,
69 DOMAIN_ALIAS_RID_POWER_USERS, 0, 0, 0, 0, 0,
70 0, &PowerUsersSid))
71 {
72 log_error(_("could not get SID for PowerUsers group: error code %lu\n"),
73 GetLastError());
74 exit(1);
75 }
76
77 if (!CheckTokenMembership(NULL, AdministratorsSid, &IsAdministrators) ||
78 !CheckTokenMembership(NULL, PowerUsersSid, &IsPowerUsers))
79 {
80 log_error(_("could not check access token membership: error code %lu\n"),
81 GetLastError());
82 exit(1);
83 }
84
85 FreeSid(AdministratorsSid);
86 FreeSid(PowerUsersSid);
87
88 if (IsAdministrators || IsPowerUsers)
89 return 1;
90 else
91 return 0;
92}
log_error
#define log_error(errcodefn,...)
Definition exec.c:66
_
#define _(x)
Definition elog.c:96

References _, fb(), and log_error.

Referenced by check_root().

◆ pgwin32_is_service()

int pgwin32_is_service ( void  )
extern

Definition at line 120 of file win32security.c.

121{
122 static int _is_service = -1;
123 BOOL IsMember;
124 PSID ServiceSid;
125 PSID LocalSystemSid;
126 SID_IDENTIFIER_AUTHORITY NtAuthority = {SECURITY_NT_AUTHORITY};
127 HANDLE stderr_handle;
128
129 /* Only check the first time */
130 if (_is_service != -1)
131 return _is_service;
132
133 /* Check if standard error is not valid */
134 stderr_handle = GetStdHandle(STD_ERROR_HANDLE);
135 if (stderr_handle != INVALID_HANDLE_VALUE && stderr_handle != NULL)
136 {
137 _is_service = 0;
138 return _is_service;
139 }
140
141 /* Check if running as LocalSystem */
142 if (!AllocateAndInitializeSid(&NtAuthority, 1,
143 SECURITY_LOCAL_SYSTEM_RID, 0, 0, 0, 0, 0, 0, 0,
144 &LocalSystemSid))
145 {
146 fprintf(stderr, "could not get SID for local system account\n");
147 return -1;
148 }
149
150 if (!CheckTokenMembership(NULL, LocalSystemSid, &IsMember))
151 {
152 fprintf(stderr, "could not check access token membership: error code %lu\n",
153 GetLastError());
154 FreeSid(LocalSystemSid);
155 return -1;
156 }
157 FreeSid(LocalSystemSid);
158
159 if (IsMember)
160 {
161 _is_service = 1;
162 return _is_service;
163 }
164
165 /* Check for service group membership */
166 if (!AllocateAndInitializeSid(&NtAuthority, 1,
167 SECURITY_SERVICE_RID, 0, 0, 0, 0, 0, 0, 0,
168 &ServiceSid))
169 {
170 fprintf(stderr, "could not get SID for service group: error code %lu\n",
171 GetLastError());
172 return -1;
173 }
174
175 if (!CheckTokenMembership(NULL, ServiceSid, &IsMember))
176 {
177 fprintf(stderr, "could not check access token membership: error code %lu\n",
178 GetLastError());
179 FreeSid(ServiceSid);
180 return -1;
181 }
182 FreeSid(ServiceSid);
183
184 if (IsMember)
185 _is_service = 1;
186 else
187 _is_service = 0;
188
189 return _is_service;
190}

References fb(), and fprintf.

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

◆ pgwin32_listen()

int pgwin32_listen ( SOCKET  s,
int  backlog 
)
extern

Definition at line 326 of file socket.c.

327{
328 int res;
329
330 res = listen(s, backlog);
331 if (res < 0)
332 TranslateSocketError();
333 return res;
334}
listen
#define listen(s, backlog)
Definition win32_port.h:514

References fb(), listen, and TranslateSocketError().

◆ pgwin32_putenv()

int pgwin32_putenv ( const char *  envval)
extern

Definition at line 27 of file win32env.c.

28{
29 char *envcpy;
30 char *cp;
31 typedef int (_cdecl * PUTENVPROC) (const char *);
32 static const char *const modulenames[] = {
33 "msvcrt", /* Visual Studio 6.0 / MinGW */
34 "msvcrtd",
35 "msvcr70", /* Visual Studio 2002 */
36 "msvcr70d",
37 "msvcr71", /* Visual Studio 2003 */
38 "msvcr71d",
39 "msvcr80", /* Visual Studio 2005 */
40 "msvcr80d",
41 "msvcr90", /* Visual Studio 2008 */
42 "msvcr90d",
43 "msvcr100", /* Visual Studio 2010 */
44 "msvcr100d",
45 "msvcr110", /* Visual Studio 2012 */
46 "msvcr110d",
47 "msvcr120", /* Visual Studio 2013 */
48 "msvcr120d",
49 "ucrtbase", /* Visual Studio 2015 and later */
50 "ucrtbased",
51 NULL
52 };
53 int i;
54
55 /*
56 * Update process environment, making this change visible to child
57 * processes and to CRTs initializing in the future. Do this before the
58 * _putenv() loop, for the benefit of any CRT that initializes during this
59 * pgwin32_putenv() execution, after the loop checks that CRT.
60 *
61 * Need a copy of the string so we can modify it.
62 */
63 envcpy = strdup(envval);
64 if (!envcpy)
65 return -1;
66 cp = strchr(envcpy, '=');
67 if (cp == NULL)
68 {
69 free(envcpy);
70 return -1;
71 }
72 *cp = '\0';
73 cp++;
74 if (*cp)
75 {
76 /*
77 * Only call SetEnvironmentVariable() when we are adding a variable,
78 * not when removing it. Calling it on both crashes on at least
79 * certain versions of MinGW.
80 */
81 if (!SetEnvironmentVariable(envcpy, cp))
82 {
83 free(envcpy);
84 return -1;
85 }
86 }
87 free(envcpy);
88
89 /*
90 * Each CRT has its own _putenv() symbol and copy of the environment.
91 * Update the environment in each CRT module currently loaded, so every
92 * third-party library sees this change regardless of the CRT it links
93 * against. Addresses within these modules may become invalid the moment
94 * we call FreeLibrary(), so don't cache them.
95 */
96 for (i = 0; modulenames[i]; i++)
97 {
98 HMODULE hmodule = NULL;
99 BOOL res = GetModuleHandleEx(0, modulenames[i], &hmodule);
100
101 if (res != 0 && hmodule != NULL)
102 {
103 PUTENVPROC putenvFunc;
104
105 putenvFunc = (PUTENVPROC) (pg_funcptr_t) GetProcAddress(hmodule, "_putenv");
106 if (putenvFunc)
107 putenvFunc(envval);
108 FreeLibrary(hmodule);
109 }
110 }
111
112 /*
113 * Finally, update our "own" cache. This is redundant with the loop
114 * above, except when PostgreSQL itself links to a CRT not listed above.
115 * Ideally, the loop does visit all possible CRTs, making this redundant.
116 */
117 return _putenv(envval);
118}
free
#define free(a)
Definition snowball_runtime.h:65

References fb(), free, and i.

Referenced by pgwin32_setenv(), and pgwin32_unsetenv().

◆ pgwin32_recv()

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

Definition at line 382 of file socket.c.

383{
384 WSABUF wbuf;
385 int r;
386 DWORD b;
387 DWORD flags = f;
388 int n;
389
390 if (pgwin32_poll_signals())
391 return -1;
392
393 wbuf.len = len;
394 wbuf.buf = buf;
395
396 r = WSARecv(s, &wbuf, 1, &b, &flags, NULL, NULL);
397 if (r != SOCKET_ERROR)
398 return b; /* success */
399
400 if (WSAGetLastError() != WSAEWOULDBLOCK)
401 {
402 TranslateSocketError();
403 return -1;
404 }
405
406 if (pgwin32_noblock)
407 {
408 /*
409 * No data received, and we are in "emulated non-blocking mode", so
410 * return indicating that we'd block if we were to continue.
411 */
412 errno = EWOULDBLOCK;
413 return -1;
414 }
415
416 /* We're in blocking mode, so wait for data */
417
418 for (n = 0; n < 5; n++)
419 {
420 if (pgwin32_waitforsinglesocket(s, FD_READ | FD_CLOSE | FD_ACCEPT,
421 INFINITE) == 0)
422 return -1; /* errno already set */
423
424 r = WSARecv(s, &wbuf, 1, &b, &flags, NULL, NULL);
425 if (r != SOCKET_ERROR)
426 return b; /* success */
427 if (WSAGetLastError() != WSAEWOULDBLOCK)
428 {
429 TranslateSocketError();
430 return -1;
431 }
432
433 /*
434 * There seem to be cases on win2k (at least) where WSARecv can return
435 * WSAEWOULDBLOCK even when pgwin32_waitforsinglesocket claims the
436 * socket is readable. In this case, just sleep for a moment and try
437 * again. We try up to 5 times - if it fails more than that it's not
438 * likely to ever come back.
439 */
440 pg_usleep(10000);
441 }
442 ereport(NOTICE,
443 (errmsg_internal("could not read from ready socket (after retries)")));
444 errno = EWOULDBLOCK;
445 return -1;
446}
NOTICE
#define NOTICE
Definition elog.h:36
b
int b
Definition isn.c:74
len
const void size_t len
Definition pg_crc32c_sse42.c:31
pg_usleep
void pg_usleep(long microsec)
Definition signal.c:53
pgwin32_noblock
int pgwin32_noblock
Definition socket.c:28
EWOULDBLOCK
#define EWOULDBLOCK
Definition win32_port.h:384

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

◆ pgwin32_ReserveSharedMemoryRegion()

int pgwin32_ReserveSharedMemoryRegion ( HANDLE  hChild)
extern

Definition at line 573 of file win32_shmem.c.

574{
575 void *address;
576
577 Assert(ShmemProtectiveRegion != NULL);
578 Assert(UsedShmemSegAddr != NULL);
579 Assert(UsedShmemSegSize != 0);
580
581 /* ShmemProtectiveRegion */
582 address = VirtualAllocEx(hChild, ShmemProtectiveRegion,
583 PROTECTIVE_REGION_SIZE,
584 MEM_RESERVE, PAGE_NOACCESS);
585 if (address == NULL)
586 {
587 /* Don't use FATAL since we're running in the postmaster */
588 elog(LOG, "could not reserve shared memory region (addr=%p) for child %p: error code %lu",
589 ShmemProtectiveRegion, hChild, GetLastError());
590 return false;
591 }
592 if (address != ShmemProtectiveRegion)
593 {
594 /*
595 * Should never happen - in theory if allocation granularity causes
596 * strange effects it could, so check just in case.
597 *
598 * Don't use FATAL since we're running in the postmaster.
599 */
600 elog(LOG, "reserved shared memory region got incorrect address %p, expected %p",
601 address, ShmemProtectiveRegion);
602 return false;
603 }
604
605 /* UsedShmemSegAddr */
606 address = VirtualAllocEx(hChild, UsedShmemSegAddr, UsedShmemSegSize,
607 MEM_RESERVE, PAGE_READWRITE);
608 if (address == NULL)
609 {
610 elog(LOG, "could not reserve shared memory region (addr=%p) for child %p: error code %lu",
611 UsedShmemSegAddr, hChild, GetLastError());
612 return false;
613 }
614 if (address != UsedShmemSegAddr)
615 {
616 elog(LOG, "reserved shared memory region got incorrect address %p, expected %p",
617 address, UsedShmemSegAddr);
618 return false;
619 }
620
621 return true;
622}
elog
#define elog(elevel,...)
Definition elog.h:228
PROTECTIVE_REGION_SIZE
#define PROTECTIVE_REGION_SIZE
Definition win32_shmem.c:41
ShmemProtectiveRegion
void * ShmemProtectiveRegion
Definition win32_shmem.c:42
UsedShmemSegAddr
void * UsedShmemSegAddr
Definition win32_shmem.c:45
UsedShmemSegSize
static Size UsedShmemSegSize
Definition win32_shmem.c:46

References Assert, elog, fb(), 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 
)
extern

Definition at line 517 of file socket.c.

518{
519 WSAEVENT events[FD_SETSIZE * 2]; /* worst case is readfds totally
520 * different from writefds, so
521 * 2*FD_SETSIZE sockets */
522 SOCKET sockets[FD_SETSIZE * 2];
523 int numevents = 0;
524 int r;
525 DWORD timeoutval = WSA_INFINITE;
526 FD_SET outreadfds;
527 FD_SET outwritefds;
528 int nummatches = 0;
529
530 Assert(exceptfds == NULL);
531
532 if (pgwin32_poll_signals())
533 return -1;
534
535 FD_ZERO(&outreadfds);
536 FD_ZERO(&outwritefds);
537
538 /*
539 * Windows does not guarantee to log an FD_WRITE network event indicating
540 * that more data can be sent unless the previous send() failed with
541 * WSAEWOULDBLOCK. While our caller might well have made such a call, we
542 * cannot assume that here. Therefore, if waiting for write-ready, force
543 * the issue by doing a dummy send(). If the dummy send() succeeds,
544 * assume that the socket is in fact write-ready, and return immediately.
545 * Also, if it fails with something other than WSAEWOULDBLOCK, return a
546 * write-ready indication to let our caller deal with the error condition.
547 */
548 if (writefds != NULL)
549 {
550 for (u_int i = 0; i < writefds->fd_count; i++)
551 {
552 char c;
553 WSABUF buf;
554 DWORD sent;
555
556 buf.buf = &c;
557 buf.len = 0;
558
559 r = WSASend(writefds->fd_array[i], &buf, 1, &sent, 0, NULL, NULL);
560 if (r == 0 || WSAGetLastError() != WSAEWOULDBLOCK)
561 FD_SET(writefds->fd_array[i], &outwritefds);
562 }
563
564 /* If we found any write-ready sockets, just return them immediately */
565 if (outwritefds.fd_count > 0)
566 {
567 memcpy(writefds, &outwritefds, sizeof(fd_set));
568 if (readfds)
569 FD_ZERO(readfds);
570 return outwritefds.fd_count;
571 }
572 }
573
574
575 /* Now set up for an actual select */
576
577 if (timeout != NULL)
578 {
579 /* timeoutval is in milliseconds */
580 timeoutval = timeout->tv_sec * 1000 + timeout->tv_usec / 1000;
581 }
582
583 if (readfds != NULL)
584 {
585 for (u_int i = 0; i < readfds->fd_count; i++)
586 {
587 events[numevents] = WSACreateEvent();
588 sockets[numevents] = readfds->fd_array[i];
589 numevents++;
590 }
591 }
592 if (writefds != NULL)
593 {
594 for (u_int i = 0; i < writefds->fd_count; i++)
595 {
596 if (!readfds ||
597 !FD_ISSET(writefds->fd_array[i], readfds))
598 {
599 /* If the socket is not in the read list */
600 events[numevents] = WSACreateEvent();
601 sockets[numevents] = writefds->fd_array[i];
602 numevents++;
603 }
604 }
605 }
606
607 for (int i = 0; i < numevents; i++)
608 {
609 int flags = 0;
610
611 if (readfds && FD_ISSET(sockets[i], readfds))
612 flags |= FD_READ | FD_ACCEPT | FD_CLOSE;
613
614 if (writefds && FD_ISSET(sockets[i], writefds))
615 flags |= FD_WRITE | FD_CLOSE;
616
617 if (WSAEventSelect(sockets[i], events[i], flags) != 0)
618 {
619 TranslateSocketError();
620 /* release already-assigned event objects */
621 while (--i >= 0)
622 WSAEventSelect(sockets[i], NULL, 0);
623 for (i = 0; i < numevents; i++)
624 WSACloseEvent(events[i]);
625 return -1;
626 }
627 }
628
629 events[numevents] = pgwin32_signal_event;
630 r = WaitForMultipleObjectsEx(numevents + 1, events, FALSE, timeoutval, TRUE);
631 if (r != WAIT_TIMEOUT && r != WAIT_IO_COMPLETION && r != (WAIT_OBJECT_0 + numevents))
632 {
633 /*
634 * We scan all events, even those not signaled, in case more than one
635 * event has been tagged but Wait.. can only return one.
636 */
637 WSANETWORKEVENTS resEvents;
638
639 for (int i = 0; i < numevents; i++)
640 {
641 ZeroMemory(&resEvents, sizeof(resEvents));
642 if (WSAEnumNetworkEvents(sockets[i], events[i], &resEvents) != 0)
643 elog(ERROR, "failed to enumerate network events: error code %d",
644 WSAGetLastError());
645 /* Read activity? */
646 if (readfds && FD_ISSET(sockets[i], readfds))
647 {
648 if ((resEvents.lNetworkEvents & FD_READ) ||
649 (resEvents.lNetworkEvents & FD_ACCEPT) ||
650 (resEvents.lNetworkEvents & FD_CLOSE))
651 {
652 FD_SET(sockets[i], &outreadfds);
653
654 nummatches++;
655 }
656 }
657 /* Write activity? */
658 if (writefds && FD_ISSET(sockets[i], writefds))
659 {
660 if ((resEvents.lNetworkEvents & FD_WRITE) ||
661 (resEvents.lNetworkEvents & FD_CLOSE))
662 {
663 FD_SET(sockets[i], &outwritefds);
664
665 nummatches++;
666 }
667 }
668 }
669 }
670
671 /* Clean up all the event objects */
672 for (int i = 0; i < numevents; i++)
673 {
674 WSAEventSelect(sockets[i], NULL, 0);
675 WSACloseEvent(events[i]);
676 }
677
678 if (r == WSA_WAIT_TIMEOUT)
679 {
680 if (readfds)
681 FD_ZERO(readfds);
682 if (writefds)
683 FD_ZERO(writefds);
684 return 0;
685 }
686
687 /* Signal-like events. */
688 if (r == WAIT_OBJECT_0 + numevents || r == WAIT_IO_COMPLETION)
689 {
690 pgwin32_dispatch_queued_signals();
691 errno = EINTR;
692 if (readfds)
693 FD_ZERO(readfds);
694 if (writefds)
695 FD_ZERO(writefds);
696 return -1;
697 }
698
699 /* Overwrite socket sets with our resulting values */
700 if (readfds)
701 memcpy(readfds, &outreadfds, sizeof(fd_set));
702 if (writefds)
703 memcpy(writefds, &outwritefds, sizeof(fd_set));
704 return nummatches;
705}
memcpy
memcpy(sums, checksumBaseOffsets, sizeof(checksumBaseOffsets))
c
char * c
Definition preproc-cursor.c:31
pgwin32_dispatch_queued_signals
void pgwin32_dispatch_queued_signals(void)
Definition signal.c:120
EINTR
#define EINTR
Definition win32_port.h:378

References Assert, buf, EINTR, elog, ERROR, fb(), i, memcpy(), 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 
)
extern

Definition at line 459 of file socket.c.

460{
461 WSABUF wbuf;
462 int r;
463 DWORD b;
464
465 if (pgwin32_poll_signals())
466 return -1;
467
468 wbuf.len = len;
469 wbuf.buf = (char *) buf;
470
471 /*
472 * Readiness of socket to send data to UDP socket may be not true: socket
473 * can become busy again! So loop until send or error occurs.
474 */
475 for (;;)
476 {
477 r = WSASend(s, &wbuf, 1, &b, flags, NULL, NULL);
478 if (r != SOCKET_ERROR && b > 0)
479 /* Write succeeded right away */
480 return b;
481
482 if (r == SOCKET_ERROR &&
483 WSAGetLastError() != WSAEWOULDBLOCK)
484 {
485 TranslateSocketError();
486 return -1;
487 }
488
489 if (pgwin32_noblock)
490 {
491 /*
492 * No data sent, and we are in "emulated non-blocking mode", so
493 * return indicating that we'd block if we were to continue.
494 */
495 errno = EWOULDBLOCK;
496 return -1;
497 }
498
499 /* No error, zero bytes */
500
501 if (pgwin32_waitforsinglesocket(s, FD_WRITE | FD_CLOSE, INFINITE) == 0)
502 return -1;
503 }
504
505 return -1;
506}

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

◆ pgwin32_setenv()

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

Definition at line 121 of file win32env.c.

122{
123 int res;
124 char *envstr;
125
126 /* Error conditions, per POSIX */
127 if (name == NULL || name[0] == '\0' || strchr(name, '=') != NULL ||
128 value == NULL)
129 {
130 errno = EINVAL;
131 return -1;
132 }
133
134 /* No work if variable exists and we're not to replace it */
135 if (overwrite == 0 && getenv(name) != NULL)
136 return 0;
137
138 envstr = (char *) malloc(strlen(name) + strlen(value) + 2);
139 if (!envstr) /* not much we can do if no memory */
140 return -1;
141
142 sprintf(envstr, "%s=%s", name, value);
143
144 res = pgwin32_putenv(envstr);
145 free(envstr);
146 return res;
147}
value
static struct @175 value
sprintf
#define sprintf
Definition port.h:263
malloc
#define malloc(a)
Definition snowball_runtime.h:50
overwrite
static void overwrite(PGconn *conn, Oid lobjId, int start, int len)
Definition testlo.c:108
pgwin32_putenv
int pgwin32_putenv(const char *envval)
Definition win32env.c:27

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

◆ pgwin32_setlocale()

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

Definition at line 172 of file win32setlocale.c.

173{
174 const char *argument;
175 char *result;
176
177 if (locale == NULL)
178 argument = NULL;
179 else
180 argument = map_locale(locale_map_argument, locale);
181
182 /* Call the real setlocale() function */
183 result = setlocale(category, argument);
184
185 /*
186 * setlocale() is specified to return a "char *" that the caller is
187 * forbidden to modify, so casting away the "const" is innocuous.
188 */
189 if (result)
190 result = unconstify(char *, map_locale(locale_map_result, result));
191
192 return result;
193}
unconstify
#define unconstify(underlying_type, expr)
Definition c.h:1384
setlocale
#define setlocale(a, b)
Definition win32_port.h:489
locale_map_argument
static const struct locale_map locale_map_argument[]
Definition win32setlocale.c:57
locale_map_result
static const struct locale_map locale_map_result[]
Definition win32setlocale.c:92
map_locale
static const char * map_locale(const struct locale_map *map, const char *locale)
Definition win32setlocale.c:111

References fb(), locale_map_argument, locale_map_result, map_locale(), result, setlocale, and unconstify.

◆ pgwin32_signal_initialize()

void pgwin32_signal_initialize ( void  )
extern

Definition at line 79 of file signal.c.

80{
81 int i;
82 HANDLE signal_thread_handle;
83
84 InitializeCriticalSection(&pg_signal_crit_sec);
85
86 for (i = 0; i < PG_SIGNAL_COUNT; i++)
87 {
88 pg_signal_array[i].sa_handler = SIG_DFL;
89 pg_signal_array[i].sa_mask = 0;
90 pg_signal_array[i].sa_flags = 0;
91 pg_signal_defaults[i] = PG_SIG_IGN;
92 }
93 pg_signal_mask = 0;
94 pg_signal_queue = 0;
95
96 /* Create the global event handle used to flag signals */
97 pgwin32_signal_event = CreateEvent(NULL, TRUE, FALSE, NULL);
98 if (pgwin32_signal_event == NULL)
99 ereport(FATAL,
100 (errmsg_internal("could not create signal event: error code %lu", GetLastError())));
101
102 /* Create thread for handling signals */
103 signal_thread_handle = CreateThread(NULL, 0, pg_signal_thread, NULL, 0, NULL);
104 if (signal_thread_handle == NULL)
105 ereport(FATAL,
106 (errmsg_internal("could not create signal handler thread")));
107
108 /* Create console control handle to pick up Ctrl-C etc */
109 if (!SetConsoleCtrlHandler(pg_console_handler, TRUE))
110 ereport(FATAL,
111 (errmsg_internal("could not set console control handler")));
112}
FATAL
#define FATAL
Definition elog.h:42
pg_signal_thread
static DWORD WINAPI pg_signal_thread(LPVOID param)
Definition signal.c:278
pg_console_handler
static BOOL WINAPI pg_console_handler(DWORD dwCtrlType)
Definition signal.c:383
pg_signal_mask
int pg_signal_mask
Definition signal.c:25

References ereport, errmsg_internal(), FATAL, fb(), i, pg_console_handler(), PG_SIG_IGN, 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 
)
extern

Definition at line 291 of file socket.c.

292{
293 SOCKET s;
294 unsigned long on = 1;
295
296 s = WSASocket(af, type, protocol, NULL, 0, WSA_FLAG_OVERLAPPED);
297 if (s == INVALID_SOCKET)
298 {
299 TranslateSocketError();
300 return INVALID_SOCKET;
301 }
302
303 if (ioctlsocket(s, FIONBIO, &on))
304 {
305 TranslateSocketError();
306 closesocket(s);
307 return INVALID_SOCKET;
308 }
309 errno = 0;
310
311 return s;
312}
closesocket
#define closesocket
Definition port.h:398
type
const char * type
Definition wait_event_funcs.c:28

References closesocket, fb(), TranslateSocketError(), and type.

◆ pgwin32_unsetenv()

int pgwin32_unsetenv ( const char *  name)
extern

Definition at line 150 of file win32env.c.

151{
152 int res;
153 char *envbuf;
154
155 /* Error conditions, per POSIX */
156 if (name == NULL || name[0] == '\0' || strchr(name, '=') != NULL)
157 {
158 errno = EINVAL;
159 return -1;
160 }
161
162 envbuf = (char *) malloc(strlen(name) + 2);
163 if (!envbuf)
164 return -1;
165
166 sprintf(envbuf, "%s=", name);
167 res = pgwin32_putenv(envbuf);
168 free(envbuf);
169 return res;
170}

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

◆ pgwin32_waitforsinglesocket()

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

Definition at line 181 of file socket.c.

182{
183 static HANDLE waitevent = INVALID_HANDLE_VALUE;
184 static SOCKET current_socket = INVALID_SOCKET;
185 static int isUDP = 0;
186 HANDLE events[2];
187 int r;
188
189 /* Create an event object just once and use it on all future calls */
190 if (waitevent == INVALID_HANDLE_VALUE)
191 {
192 waitevent = CreateEvent(NULL, TRUE, FALSE, NULL);
193
194 if (waitevent == INVALID_HANDLE_VALUE)
195 ereport(ERROR,
196 (errmsg_internal("could not create socket waiting event: error code %lu", GetLastError())));
197 }
198 else if (!ResetEvent(waitevent))
199 ereport(ERROR,
200 (errmsg_internal("could not reset socket waiting event: error code %lu", GetLastError())));
201
202 /*
203 * Track whether socket is UDP or not. (NB: most likely, this is both
204 * useless and wrong; there is no reason to think that the behavior of
205 * WSAEventSelect is different for TCP and UDP.)
206 */
207 if (current_socket != s)
208 isUDP = isDataGram(s);
209 current_socket = s;
210
211 /*
212 * Attach event to socket. NOTE: we must detach it again before
213 * returning, since other bits of code may try to attach other events to
214 * the socket.
215 */
216 if (WSAEventSelect(s, waitevent, what) != 0)
217 {
218 TranslateSocketError();
219 return 0;
220 }
221
222 events[0] = pgwin32_signal_event;
223 events[1] = waitevent;
224
225 /*
226 * Just a workaround of unknown locking problem with writing in UDP socket
227 * under high load: Client's pgsql backend sleeps infinitely in
228 * WaitForMultipleObjectsEx, pgstat process sleeps in pgwin32_select().
229 * So, we will wait with small timeout(0.1 sec) and if socket is still
230 * blocked, try WSASend (see comments in pgwin32_select) and wait again.
231 */
232 if ((what & FD_WRITE) && isUDP)
233 {
234 for (;;)
235 {
236 r = WaitForMultipleObjectsEx(2, events, FALSE, 100, TRUE);
237
238 if (r == WAIT_TIMEOUT)
239 {
240 char c;
241 WSABUF buf;
242 DWORD sent;
243
244 buf.buf = &c;
245 buf.len = 0;
246
247 r = WSASend(s, &buf, 1, &sent, 0, NULL, NULL);
248 if (r == 0) /* Completed - means things are fine! */
249 {
250 WSAEventSelect(s, NULL, 0);
251 return 1;
252 }
253 else if (WSAGetLastError() != WSAEWOULDBLOCK)
254 {
255 TranslateSocketError();
256 WSAEventSelect(s, NULL, 0);
257 return 0;
258 }
259 }
260 else
261 break;
262 }
263 }
264 else
265 r = WaitForMultipleObjectsEx(2, events, FALSE, timeout, TRUE);
266
267 WSAEventSelect(s, NULL, 0);
268
269 if (r == WAIT_OBJECT_0 || r == WAIT_IO_COMPLETION)
270 {
271 pgwin32_dispatch_queued_signals();
272 errno = EINTR;
273 return 0;
274 }
275 if (r == WAIT_OBJECT_0 + 1)
276 return 1;
277 if (r == WAIT_TIMEOUT)
278 {
279 errno = EWOULDBLOCK;
280 return 0;
281 }
282 ereport(ERROR,
283 (errmsg_internal("unrecognized return value from WaitForMultipleObjects: %d (error code %lu)", r, GetLastError())));
284 return 0;
285}
isDataGram
static int isDataGram(SOCKET s)
Definition socket.c:169

References buf, EINTR, ereport, errmsg_internal(), ERROR, EWOULDBLOCK, fb(), 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.

87{
88 Assert(value != NULL);
89 Assert(value->it_interval.tv_sec == 0 && value->it_interval.tv_usec == 0);
90 Assert(which == ITIMER_REAL);
91
92 if (timerThreadHandle == INVALID_HANDLE_VALUE)
93 {
94 /* First call in this backend, create event and the timer thread */
95 timerCommArea.event = CreateEvent(NULL, TRUE, FALSE, NULL);
96 if (timerCommArea.event == NULL)
97 ereport(FATAL,
98 (errmsg_internal("could not create timer event: error code %lu",
99 GetLastError())));
100
101 MemSet(&timerCommArea.value, 0, sizeof(struct itimerval));
102
103 InitializeCriticalSection(&timerCommArea.crit_sec);
104
105 timerThreadHandle = CreateThread(NULL, 0, pg_timer_thread, NULL, 0, NULL);
106 if (timerThreadHandle == INVALID_HANDLE_VALUE)
107 ereport(FATAL,
108 (errmsg_internal("could not create timer thread: error code %lu",
109 GetLastError())));
110 }
111
112 /* Request the timer thread to change settings */
113 EnterCriticalSection(&timerCommArea.crit_sec);
114 if (ovalue)
115 *ovalue = timerCommArea.value;
116 timerCommArea.value = *value;
117 LeaveCriticalSection(&timerCommArea.crit_sec);
118 SetEvent(timerCommArea.event);
119
120 return 0;
121}
MemSet
#define MemSet(start, val, len)
Definition c.h:1166
timerCA::crit_sec
CRITICAL_SECTION crit_sec
Definition timer.c:27
timerCA::value
struct itimerval value
Definition timer.c:25
timerCA::event
HANDLE event
Definition timer.c:26
timerCommArea
static timerCA timerCommArea
Definition timer.c:30
pg_timer_thread
static DWORD WINAPI pg_timer_thread(LPVOID param)
Definition timer.c:36
timerThreadHandle
static HANDLE timerThreadHandle
Definition timer.c:31
ITIMER_REAL
#define ITIMER_REAL
Definition win32_port.h:180

References Assert, timerCA::crit_sec, ereport, errmsg_internal(), timerCA::event, FATAL, fb(), 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().