#ifdef _WIN32

#define WIN32_LEAN_AND_MEAN

#include <winsock2.h>

#include <ws2tcpip.h>

#include <afunix.h>

#include <assert.h>

#include <windows.h>

#include <direct.h>

#include <errno.h>

#include <fcntl.h>

#include <io.h>

#include <process.h>

#include <stdint.h>

#include <stdio.h>

#include <stdlib.h>

#include <string.h>

#include <sys/stat.h>

#include <sys/types.h>

#include "errno_capture.h"

#ifndef SO_UPDATE_ACCEPT_CONTEXT

#define SO_UPDATE_ACCEPT_CONTEXT 0x700B

#ifndef ENOTSUP

#define ENOTSUP ENOSYS

#ifndef EWOULDBLOCK

#define EWOULDBLOCK 11

#ifndef EOVERFLOW

#define EOVERFLOW 75

#ifndef EALREADY

#define EALREADY 114

#ifndef EINPROGRESS

#define EINPROGRESS 115

#ifndef ENOTSOCK

#define ENOTSOCK 88

#ifndef EDESTADDRREQ

#define EDESTADDRREQ 89

#ifndef EMSGSIZE

#define EMSGSIZE 90

#ifndef EPROTOTYPE

#define EPROTOTYPE 91

#ifndef ENOPROTOOPT

#define ENOPROTOOPT 92

#ifndef EPROTONOSUPPORT

#define EPROTONOSUPPORT 93

#ifndef EAFNOSUPPORT

#define EAFNOSUPPORT 97

#ifndef EADDRINUSE

#define EADDRINUSE 98

#ifndef EADDRNOTAVAIL

#define EADDRNOTAVAIL 99

#ifndef ENETDOWN

#define ENETDOWN 100

#ifndef ENETUNREACH

#define ENETUNREACH 101

#ifndef ENETRESET

#define ENETRESET 102

#ifndef ECONNABORTED

#define ECONNABORTED 103

#ifndef ECONNRESET

#define ECONNRESET 104

#ifndef ENOBUFS

#define ENOBUFS 105

#ifndef EISCONN

#define EISCONN 106

#ifndef ENOTCONN

#define ENOTCONN 107

#ifndef ETIMEDOUT

#define ETIMEDOUT 110

#ifndef ECONNREFUSED

#define ECONNREFUSED 111

#ifndef EHOSTUNREACH

#define EHOSTUNREACH 113

#define GP_EWOULDBLOCK 11

#define GP_EINPROGRESS 115

#define GP_EALREADY 114

#define GP_ENOTSOCK 88

#define GP_EDESTADDRREQ 89

#define GP_EMSGSIZE 90

#define GP_EPROTOTYPE 91

#define GP_ENOPROTOOPT 92

#define GP_EPROTONOSUPPORT 93

#define GP_EAFNOSUPPORT 97

#define GP_EADDRINUSE 98

#define GP_EADDRNOTAVAIL 99

#define GP_ENETDOWN 100

#define GP_ENETUNREACH 101

#define GP_ENETRESET 102

#define GP_ECONNABORTED 103

#define GP_ECONNRESET 104

#define GP_ENOBUFS 105

#define GP_EISCONN 106

#define GP_ENOTCONN 107

#define GP_ETIMEDOUT 110

#define GP_ECONNREFUSED 111

#define GP_EHOSTUNREACH 113

#define GP_EXPORT __declspec(dllexport)

THREAD_LOCAL int errno_capture = 0;

THREAD_LOCAL int winerror_capture = 0;

THREAD_LOCAL int wsaerror_capture = 0;

THREAD_LOCAL int error_source_capture = ERROR_CAPTURE_ERRNO;

#define WIN_AT_FDCWD (-100)

#define WIN_GRAALPY_DEFAULT_DIR_FD (-1)

#define WIN_DT_UNKNOWN 0

typedef struct {

HANDLE handle;

WIN32_FIND_DATAW data;

int first;

int exhausted;

} win_dir_t;

static void silent_invalid_parameter_handler(const wchar_t *expression, const wchar_t *function, const wchar_t *file, unsigned int line, uintptr_t reserved) {

(void) expression;

(void) function;

(void) file;

(void) line;

(void) reserved;

}

#if defined(_MSC_VER) && _MSC_VER >= 1900

#define BEGIN_SUPPRESS_IPH \

{ _invalid_parameter_handler old_handler = _set_thread_local_invalid_parameter_handler(silent_invalid_parameter_handler);

#define END_SUPPRESS_IPH \

_set_thread_local_invalid_parameter_handler(old_handler); }

#define BEGIN_SUPPRESS_IPH

#define END_SUPPRESS_IPH

static int is_default_dir_fd(int32_t dirFd) {

return dirFd == 0 || dirFd < 0 || dirFd == WIN_AT_FDCWD || dirFd == WIN_GRAALPY_DEFAULT_DIR_FD;

}

static int unsupported(void) {

errno = ENOSYS;

capture_errno();

return -1;

}

static void set_posix_errno(int error) {

errno = error;

capture_errors();

}

static void set_win_errno(DWORD error) {

capture_errors();

winerror_capture = (int) error;

error_source_capture = ERROR_CAPTURE_WINAPI;

}

static int ensure_winsock(void) {

static int initialized = 0;

if (!initialized) {

WSADATA wsa_data;

int err = WSAStartup(MAKEWORD(2, 2), &wsa_data);

if (err != 0) {

capture_errors();

wsaerror_capture = err;

error_source_capture = ERROR_CAPTURE_WINSOCK;

return -1;

}

initialized = 1;

}

return 0;

}

static int set_wsa_errno_from_error(int error) {

capture_errors();

wsaerror_capture = error;

error_source_capture = ERROR_CAPTURE_WINSOCK;

return -1;

}

static int set_wsa_errno(void) {

return set_wsa_errno_from_error(WSAGetLastError());

}

static int close_noraise(int32_t fd) {

int result;

BEGIN_SUPPRESS_IPH

result = _close(fd);

END_SUPPRESS_IPH

if (result < 0) {

capture_errno();

}

return result;

}

static int64_t read_noraise(int32_t fd, void *buf, unsigned int count) {

int result;

BEGIN_SUPPRESS_IPH

result = _read(fd, buf, count);

END_SUPPRESS_IPH

if (result < 0) {

capture_errno();

}

return result;

}

static int64_t write_noraise(int32_t fd, void *buf, unsigned int count) {

int result;

BEGIN_SUPPRESS_IPH

result = _write(fd, buf, count);

END_SUPPRESS_IPH

if (result < 0) {

capture_errno();

}

return result;

}

static int64_t lseek_noraise(int32_t fd, int64_t offset, int32_t whence) {

int64_t result;

BEGIN_SUPPRESS_IPH

result = _lseeki64(fd, offset, whence);

END_SUPPRESS_IPH

if (result < 0) {

capture_errno();

}

return result;

}

static int chsize_noraise(int32_t fd, int64_t length) {

int result;

BEGIN_SUPPRESS_IPH

result = _chsize_s(fd, length);

END_SUPPRESS_IPH

if (result != 0) {

errno = result;

capture_errno();

}

return result;

}

static int commit_noraise(int32_t fd) {

int result;

BEGIN_SUPPRESS_IPH

result = _commit(fd);

END_SUPPRESS_IPH

if (result < 0) {

capture_errno();

}

return result;

}

static int dup_noraise(int32_t fd) {

int result;

BEGIN_SUPPRESS_IPH

result = _dup(fd);

END_SUPPRESS_IPH

if (result < 0) {

capture_errno();

}

return result;

}

static int dup2_noraise(int32_t oldfd, int32_t newfd) {

int result;

BEGIN_SUPPRESS_IPH

result = _dup2(oldfd, newfd);

END_SUPPRESS_IPH

if (result < 0) {

capture_errno();

}

return result;

}

typedef struct {

int fd;

SOCKET socket;

int blocking;

} win_socket_entry_t;

typedef struct {

void *view;

HANDLE mapping;

} win_mmap_entry_t;

#define WIN_SOCKET_TABLE_SIZE 1024

#define WIN_MMAP_TABLE_SIZE 1024

static win_socket_entry_t win_socket_table[WIN_SOCKET_TABLE_SIZE];

static INIT_ONCE win_socket_table_init_once = INIT_ONCE_STATIC_INIT;

static CRITICAL_SECTION win_socket_table_lock;

static win_mmap_entry_t win_mmap_table[WIN_MMAP_TABLE_SIZE];

static INIT_ONCE win_mmap_table_init_once = INIT_ONCE_STATIC_INIT;

static CRITICAL_SECTION win_mmap_table_lock;

static BOOL CALLBACK win_socket_table_init(PINIT_ONCE init_once, PVOID parameter, PVOID *context) {

(void) init_once;

(void) parameter;

(void) context;

InitializeCriticalSection(&win_socket_table_lock);

for (int i = 0; i < WIN_SOCKET_TABLE_SIZE; i++) {

win_socket_table[i].fd = -1;

win_socket_table[i].socket = INVALID_SOCKET;

win_socket_table[i].blocking = 1;

}

return TRUE;

}

static void ensure_socket_table(void) {

InitOnceExecuteOnce(&win_socket_table_init_once, win_socket_table_init, NULL, NULL);

}

static BOOL CALLBACK win_mmap_table_init(PINIT_ONCE init_once, PVOID parameter, PVOID *context) {

(void) init_once;

(void) parameter;

(void) context;

InitializeCriticalSection(&win_mmap_table_lock);

for (int i = 0; i < WIN_MMAP_TABLE_SIZE; i++) {

win_mmap_table[i].view = NULL;

win_mmap_table[i].mapping = NULL;

}

return TRUE;

}

static void ensure_mmap_table(void) {

InitOnceExecuteOnce(&win_mmap_table_init_once, win_mmap_table_init, NULL, NULL);

}

static int win_add_mmap(void *view, HANDLE mapping) {

ensure_mmap_table();

EnterCriticalSection(&win_mmap_table_lock);

for (int i = 0; i < WIN_MMAP_TABLE_SIZE; i++) {

if (win_mmap_table[i].view == NULL) {

win_mmap_table[i].view = view;

win_mmap_table[i].mapping = mapping;

LeaveCriticalSection(&win_mmap_table_lock);

return 0;

}

}

LeaveCriticalSection(&win_mmap_table_lock);

set_posix_errno(ENOMEM);

return -1;

}

static HANDLE win_remove_mmap(void *view) {

HANDLE mapping = NULL;

ensure_mmap_table();

EnterCriticalSection(&win_mmap_table_lock);

for (int i = 0; i < WIN_MMAP_TABLE_SIZE; i++) {

if (win_mmap_table[i].view == view) {

mapping = win_mmap_table[i].mapping;

win_mmap_table[i].view = NULL;

win_mmap_table[i].mapping = NULL;

break;

}

}

LeaveCriticalSection(&win_mmap_table_lock);

return mapping;

}

static SOCKET win_socket_from_fd(int32_t fd) {

SOCKET result = INVALID_SOCKET;

ensure_socket_table();

EnterCriticalSection(&win_socket_table_lock);

for (int i = 0; i < WIN_SOCKET_TABLE_SIZE; i++) {

if (win_socket_table[i].fd == fd) {

result = win_socket_table[i].socket;

break;

}

}

LeaveCriticalSection(&win_socket_table_lock);

return result;

}

static int win_socket_blocking_from_fd(int32_t fd) {

int result = 1;

ensure_socket_table();

EnterCriticalSection(&win_socket_table_lock);

for (int i = 0; i < WIN_SOCKET_TABLE_SIZE; i++) {

if (win_socket_table[i].fd == fd) {

result = win_socket_table[i].blocking;

break;

}

}

LeaveCriticalSection(&win_socket_table_lock);

return result;

}

static int win_socket_entry_index(int32_t fd) {

int result = -1;

ensure_socket_table();

EnterCriticalSection(&win_socket_table_lock);

for (int i = 0; i < WIN_SOCKET_TABLE_SIZE; i++) {

if (win_socket_table[i].fd == fd) {

result = i;

break;

}

}

LeaveCriticalSection(&win_socket_table_lock);

return result;

}

static int win_alloc_socket_fd(SOCKET s, int blocking) {

int fd = _open("NUL", _O_RDONLY | _O_BINARY | _O_NOINHERIT);

if (fd < 0) {

capture_errno();

closesocket(s);

return -1;

}

ensure_socket_table();

EnterCriticalSection(&win_socket_table_lock);

for (int i = 0; i < WIN_SOCKET_TABLE_SIZE; i++) {

if (win_socket_table[i].fd < 0) {

win_socket_table[i].fd = fd;

win_socket_table[i].socket = s;

win_socket_table[i].blocking = blocking;

LeaveCriticalSection(&win_socket_table_lock);

return fd;

}

}

LeaveCriticalSection(&win_socket_table_lock);

close_noraise(fd);

closesocket(s);

set_posix_errno(EMFILE);

return -1;

}

static SOCKET win_remove_socket_fd(int32_t fd) {

SOCKET result = INVALID_SOCKET;

ensure_socket_table();

EnterCriticalSection(&win_socket_table_lock);

for (int i = 0; i < WIN_SOCKET_TABLE_SIZE; i++) {

if (win_socket_table[i].fd == fd) {

result = win_socket_table[i].socket;

win_socket_table[i].fd = -1;

win_socket_table[i].socket = INVALID_SOCKET;

win_socket_table[i].blocking = 1;

break;

}

}

LeaveCriticalSection(&win_socket_table_lock);

return result;

}

GP_EXPORT int32_t set_inheritable(int32_t fd, int32_t inheritable);

static int win_replace_socket_fd_locked(int32_t fd, SOCKET s, int blocking, SOCKET *replaced) {

assert(win_socket_table_lock.OwningThread == (HANDLE) (uintptr_t) GetCurrentThreadId());

int free_index = -1;

for (int i = 0; i < WIN_SOCKET_TABLE_SIZE; i++) {

if (win_socket_table[i].fd == fd) {

*replaced = win_socket_table[i].socket;

win_socket_table[i].socket = s;

win_socket_table[i].blocking = blocking;

return 0;

}

if (free_index < 0 && win_socket_table[i].fd < 0) {

free_index = i;

}

}

if (free_index < 0) {

set_posix_errno(EMFILE);

return -1;

}

win_socket_table[free_index].fd = fd;

win_socket_table[free_index].socket = s;

win_socket_table[free_index].blocking = blocking;

*replaced = INVALID_SOCKET;

return 0;

}

static SOCKET win_duplicate_socket(SOCKET s) {

WSAPROTOCOL_INFOA protocol_info;

if (WSADuplicateSocketA(s, GetCurrentProcessId(), &protocol_info) == SOCKET_ERROR) {

set_wsa_errno();

return INVALID_SOCKET;

}

SOCKET dup = WSASocketA(FROM_PROTOCOL_INFO, FROM_PROTOCOL_INFO, FROM_PROTOCOL_INFO, &protocol_info, 0, WSA_FLAG_NO_HANDLE_INHERIT);

if (dup == INVALID_SOCKET) {

set_wsa_errno();

return INVALID_SOCKET;

}

return dup;

}

static int win_socket_dup(int32_t fd) {

SOCKET s = win_socket_from_fd(fd);

int blocking = win_socket_blocking_from_fd(fd);

SOCKET dup = win_duplicate_socket(s);

if (dup == INVALID_SOCKET) {

return -1;

}

return win_alloc_socket_fd(dup, blocking);

}

static int win_socket_dup2(int32_t oldfd, int32_t newfd, int32_t inheritable) {

SOCKET dup = win_duplicate_socket(win_socket_from_fd(oldfd));

if (dup == INVALID_SOCKET) {

return -1;

}

int blocking = win_socket_blocking_from_fd(oldfd);

/*

ensure_socket_table();

EnterCriticalSection(&win_socket_table_lock);

int table_has_slot = 0;

for (int i = 0; i < WIN_SOCKET_TABLE_SIZE; i++) {

if (win_socket_table[i].fd == newfd || win_socket_table[i].fd < 0) {

table_has_slot = 1;

break;

}

}

if (!table_has_slot) {

LeaveCriticalSection(&win_socket_table_lock);

closesocket(dup);

set_posix_errno(EMFILE);

return -1;

}

if (dup2_noraise(oldfd, newfd) != 0) {

LeaveCriticalSection(&win_socket_table_lock);

closesocket(dup);

return -1;

}

SOCKET replaced = INVALID_SOCKET;

int replaced_result = win_replace_socket_fd_locked(newfd, dup, blocking, &replaced);

LeaveCriticalSection(&win_socket_table_lock);

if (replaced_result < 0) {

closesocket(dup);

return -1;

}

if (replaced != INVALID_SOCKET) {

closesocket(replaced);

}

if (!inheritable) {

return set_inheritable(newfd, 0);

}

return 0;

}

static intptr_t get_osfhandle_noraise(int32_t fd) {

intptr_t handle;

BEGIN_SUPPRESS_IPH

handle = _get_osfhandle(fd);

END_SUPPRESS_IPH

if (handle == -1) {

capture_errno();

}

return handle;

}

static int open_osfhandle_noraise(int64_t handle, int32_t flags) {

int fd;

BEGIN_SUPPRESS_IPH

fd = _open_osfhandle((intptr_t) handle, flags);

END_SUPPRESS_IPH

if (fd < 0) {

capture_errno();

}

return fd;

}

static void unix_time_to_filetime(int64_t seconds, int64_t nanoseconds, FILETIME *out) {

int64_t ticks = (seconds + 11644473600LL) * 10000000LL + nanoseconds / 100;

out->dwLowDateTime = (DWORD) ticks;

out->dwHighDateTime = (DWORD) (ticks >> 32);

}

static int64_t filetime_to_unix_time(FILETIME time) {

ULARGE_INTEGER ticks;

ticks.LowPart = time.dwLowDateTime;

ticks.HighPart = time.dwHighDateTime;

return (int64_t) (ticks.QuadPart / 10000000ULL) - 11644473600LL;

}

static int set_file_times(HANDLE handle, int64_t *times, int32_t nanosecond_resolution) {

FILETIME atime;

FILETIME mtime;

if (times == NULL) {

GetSystemTimeAsFileTime(&mtime);

atime = mtime;

} else {

unix_time_to_filetime(times[0], nanosecond_resolution ? times[1] : times[1] * 1000, &atime);

unix_time_to_filetime(times[2], nanosecond_resolution ? times[3] : times[3] * 1000, &mtime);

}

if (!SetFileTime(handle, NULL, &atime, &mtime)) {

set_win_errno(GetLastError());

return -1;

}

return 0;

}

static int set_path_times(const wchar_t *path, int64_t *times, int32_t nanosecond_resolution, int32_t followSymlinks) {

DWORD flags = FILE_FLAG_BACKUP_SEMANTICS;

if (!followSymlinks) {

flags |= FILE_FLAG_OPEN_REPARSE_POINT;

}

HANDLE handle = CreateFileW(path, FILE_WRITE_ATTRIBUTES, FILE_SHARE_READ | FILE_SHARE_WRITE | FILE_SHARE_DELETE,

NULL, OPEN_EXISTING, flags, NULL);

if (handle == INVALID_HANDLE_VALUE) {

set_win_errno(GetLastError());

return -1;

}

int result = set_file_times(handle, times, nanosecond_resolution);

CloseHandle(handle);

return result;

}

static int root_path_from_path(const wchar_t *path, wchar_t *root, DWORD root_size) {

wchar_t full_path[32768];

DWORD full_len = GetFullPathNameW(path, (DWORD) (sizeof(full_path) / sizeof(wchar_t)), full_path, NULL);

if (full_len == 0 || full_len >= sizeof(full_path) / sizeof(wchar_t)) {

set_win_errno(GetLastError());

return -1;

}

if (!GetVolumePathNameW(full_path, root, root_size)) {

set_win_errno(GetLastError());

return -1;

}

return 0;

}

static int statvfs_from_root(const wchar_t *root, int64_t *out) {

ULARGE_INTEGER free_bytes_available;

ULARGE_INTEGER total_number_of_bytes;

ULARGE_INTEGER total_number_of_free_bytes;

DWORD sectors_per_cluster = 0;

DWORD bytes_per_sector = 0;

DWORD number_of_free_clusters = 0;

DWORD total_number_of_clusters = 0;

if (!GetDiskFreeSpaceExW(root, &free_bytes_available, &total_number_of_bytes, &total_number_of_free_bytes)) {

set_win_errno(GetLastError());

return -1;

}

if (!GetDiskFreeSpaceW(root, &sectors_per_cluster, &bytes_per_sector, &number_of_free_clusters, &total_number_of_clusters)) {

sectors_per_cluster = 1;

bytes_per_sector = 4096;

}

uint64_t block_size = (uint64_t) sectors_per_cluster * bytes_per_sector;

if (block_size == 0) {

block_size = 4096;

}

out[0] = (int64_t) block_size;

out[1] = (int64_t) block_size;

out[2] = (int64_t) (total_number_of_bytes.QuadPart / block_size);

out[3] = (int64_t) (total_number_of_free_bytes.QuadPart / block_size);

out[4] = (int64_t) (free_bytes_available.QuadPart / block_size);

out[5] = 0;

out[6] = 0;

out[7] = 0;

out[8] = 0;

out[9] = 255;

out[10] = 0;

return 0;

}

static int statvfs_from_path(const wchar_t *path, int64_t *out) {

DWORD attributes = GetFileAttributesW(path);

if (attributes == INVALID_FILE_ATTRIBUTES) {

set_win_errno(GetLastError());

return -1;

}

wchar_t root[MAX_PATH];

if (root_path_from_path(path, root, MAX_PATH) != 0) {

return -1;

}

return statvfs_from_root(root, out);

}

static int copy_string_to_buffer(char *buffer, int32_t bufferSize, size_t *offset, const char *value, uint64_t *out, int32_t outIndex) {

size_t len = strlen(value) + 1;

if (*offset + len > (size_t) bufferSize) {

return ERANGE;

}

out[outIndex] = *offset;

memcpy(buffer + *offset, value, len);

*offset += len;

return 0;

}

static int get_current_username(char *buffer, DWORD size) {

const char *env_name = getenv("USERNAME");

if (env_name != NULL && strlen(env_name) < size) {

strcpy(buffer, env_name);

return 0;

}

if (size > 4) {

strcpy(buffer, "user");

return 0;

}

return ERANGE;

}

static void get_current_home(char *buffer, size_t size) {

const char *profile = getenv("USERPROFILE");

if (profile != NULL && strlen(profile) < size) {

strcpy(buffer, profile);

return;

}

const char *drive = getenv("HOMEDRIVE");

const char *path = getenv("HOMEPATH");

if (drive != NULL && path != NULL && strlen(drive) + strlen(path) < size) {

strcpy(buffer, drive);

strcat(buffer, path);

return;

}

if (size > 0) {

buffer[0] = '\0';

}

}

static int fill_current_pwd(uint64_t uid, char *buffer, int32_t bufferSize, uint64_t *output) {

char name[256];

char dir[1024];

const char *shell = getenv("COMSPEC");

size_t offset = 0;

int result = get_current_username(name, sizeof(name));

if (result != 0) {

return result;

}

get_current_home(dir, sizeof(dir));

if (shell == NULL) {

shell = "";

}

if ((result = copy_string_to_buffer(buffer, bufferSize, &offset, name, output, 0)) != 0) {

return result;

}

output[1] = uid;

output[2] = 0;

if ((result = copy_string_to_buffer(buffer, bufferSize, &offset, dir, output, 3)) != 0) {

return result;

}

return copy_string_to_buffer(buffer, bufferSize, &offset, shell, output, 4);

}

static void stat_struct_to_longs(struct __stat64 *st, int64_t *out) {

out[0] = st->st_mode;

out[1] = st->st_ino;

out[2] = st->st_dev;

out[3] = st->st_nlink;

out[4] = st->st_uid;

out[5] = st->st_gid;

out[6] = st->st_size;

out[7] = st->st_atime;

out[8] = st->st_mtime;

out[9] = st->st_ctime;

out[10] = 0;

out[11] = 0;

out[12] = 0;

}

static void stat_handle_to_longs(HANDLE handle, int64_t *out) {

BY_HANDLE_FILE_INFORMATION info;

if (GetFileInformationByHandle(handle, &info)) {

out[1] = ((int64_t) info.nFileIndexHigh << 32) | info.nFileIndexLow;

out[2] = info.dwVolumeSerialNumber;

out[3] = info.nNumberOfLinks;

out[7] = filetime_to_unix_time(info.ftLastAccessTime);

out[8] = filetime_to_unix_time(info.ftLastWriteTime);

out[9] = filetime_to_unix_time(info.ftCreationTime);

}

}

static void stat_path_handle_to_longs(const wchar_t *path, int32_t followSymlinks, int64_t *out) {

DWORD flags = FILE_FLAG_BACKUP_SEMANTICS;

if (!followSymlinks) {

flags |= FILE_FLAG_OPEN_REPARSE_POINT;

}

HANDLE handle = CreateFileW(path, FILE_READ_ATTRIBUTES, FILE_SHARE_READ | FILE_SHARE_WRITE | FILE_SHARE_DELETE, NULL, OPEN_EXISTING, flags, NULL);

if (handle != INVALID_HANDLE_VALUE) {

stat_handle_to_longs(handle, out);

CloseHandle(handle);

}

}

static void stat_attributes_to_longs(DWORD attributes, DWORD sizeHigh, DWORD sizeLow, FILETIME accessTime, FILETIME writeTime, FILETIME creationTime, int64_t *out) {

memset(out, 0, 13 * sizeof(*out));

if (attributes & FILE_ATTRIBUTE_DIRECTORY) {

out[0] = _S_IFDIR | 0111;

} else {

out[0] = _S_IFREG;

}

out[0] |= attributes & FILE_ATTRIBUTE_READONLY ? 0444 : 0666;

out[3] = 1;

out[6] = ((int64_t) sizeHigh << 32) | sizeLow;

out[7] = filetime_to_unix_time(accessTime);

out[8] = filetime_to_unix_time(writeTime);

out[9] = filetime_to_unix_time(creationTime);

}

static int stat_path_attributes_to_longs(const wchar_t *path, int64_t *out) {

WIN32_FILE_ATTRIBUTE_DATA info;

if (GetFileAttributesExW(path, GetFileExInfoStandard, &info)) {

stat_attributes_to_longs(info.dwFileAttributes, info.nFileSizeHigh, info.nFileSizeLow,

info.ftLastAccessTime, info.ftLastWriteTime, info.ftCreationTime, out);

return 0;

}

DWORD error = GetLastError();

if (error != ERROR_ACCESS_DENIED && error != ERROR_SHARING_VIOLATION) {

set_win_errno(error);

return -1;

}

WIN32_FIND_DATAW findInfo;

HANDLE findHandle = FindFirstFileW(path, &findInfo);

if (findHandle == INVALID_HANDLE_VALUE) {

DWORD findError = GetLastError();

switch (findError) {

case ERROR_FILE_NOT_FOUND:

case ERROR_PATH_NOT_FOUND:

case ERROR_NOT_READY:

case ERROR_BAD_NET_NAME:

error = findError;

break;

}

set_win_errno(error);

return -1;

}

stat_attributes_to_longs(findInfo.dwFileAttributes, findInfo.nFileSizeHigh, findInfo.nFileSizeLow,

findInfo.ftLastAccessTime, findInfo.ftLastWriteTime, findInfo.ftCreationTime, out);

FindClose(findHandle);

return 0;

}

GP_EXPORT int64_t call_getpid(void) {

return _getpid();

}

GP_EXPORT int32_t call_umask(int32_t mask) {

return _umask(mask);

}

GP_EXPORT int32_t get_inheritable(int32_t fd) {

int socket_index = win_socket_entry_index(fd);

if (socket_index >= 0) {

DWORD flags;

SOCKET s = win_socket_from_fd(fd);

if (!GetHandleInformation((HANDLE) s, &flags)) {

set_win_errno(GetLastError());

return -1;

}

return (flags & HANDLE_FLAG_INHERIT) != 0;

}

intptr_t os_handle = get_osfhandle_noraise(fd);

if (os_handle == -1) {

return -1;

}

DWORD flags;

if (!GetHandleInformation((HANDLE) os_handle, &flags)) {

set_win_errno(GetLastError());

return -1;

}

return (flags & HANDLE_FLAG_INHERIT) != 0;

}

GP_EXPORT int32_t set_inheritable(int32_t fd, int32_t inheritable) {

int socket_index = win_socket_entry_index(fd);

if (socket_index >= 0) {

SOCKET s = win_socket_from_fd(fd);

if (!SetHandleInformation((HANDLE) s, HANDLE_FLAG_INHERIT, inheritable ? HANDLE_FLAG_INHERIT : 0)) {

set_win_errno(GetLastError());

return -1;

}

intptr_t reserve_handle = get_osfhandle_noraise(fd);

if (reserve_handle != -1) {

SetHandleInformation((HANDLE) reserve_handle, HANDLE_FLAG_INHERIT, inheritable ? HANDLE_FLAG_INHERIT : 0);

}

return 0;

}

intptr_t os_handle = get_osfhandle_noraise(fd);

if (os_handle == -1) {

return -1;

}

if (!SetHandleInformation((HANDLE) os_handle, HANDLE_FLAG_INHERIT, inheritable ? HANDLE_FLAG_INHERIT : 0)) {

set_win_errno(GetLastError());

return -1;

}

return 0;

}

GP_EXPORT int32_t call_openat(int32_t dirFd, const wchar_t *pathname, int32_t flags, int32_t mode) {

if (!is_default_dir_fd(dirFd)) {

return unsupported();

}

int open_flags = flags | _O_NOINHERIT;

if ((open_flags & _O_TEXT) == 0) {

open_flags |= _O_BINARY;

}

int result = _wopen(pathname, open_flags, mode);

// The following _setmode is defensive enforcement; _wopen(..., _O_BINARY, ...) should already set this mode.

if (result < 0) {

capture_errno();

} else if ((open_flags & _O_TEXT) == 0 && _setmode(result, _O_BINARY) < 0) {

int error = errno;

close_noraise(result);

set_posix_errno(error);

return -1;

}

return result;

}

GP_EXPORT int32_t call_close(int32_t fd) {

SOCKET s = win_remove_socket_fd(fd);

if (s != INVALID_SOCKET) {

int socket_result = closesocket(s);

int socket_error = socket_result == SOCKET_ERROR ? WSAGetLastError() : 0;

int fd_result = close_noraise(fd);

if (socket_result == SOCKET_ERROR) {

return set_wsa_errno_from_error(socket_error);

}

return fd_result;

}

return close_noraise(fd);

}

GP_EXPORT int64_t call_read(int32_t fd, void *buf, uint64_t count) {

if (win_socket_entry_index(fd) >= 0) {

int result = recv(win_socket_from_fd(fd), buf, count > INT_MAX ? INT_MAX : (int) count, 0);

return result == SOCKET_ERROR ? set_wsa_errno() : result;

}

return read_noraise(fd, buf, count > INT_MAX ? INT_MAX : (unsigned int) count);

}