X-Git-Url: https://wimlib.net/git/?p=wimlib;a=blobdiff_plain;f=src%2Fwin32_replacements.c;h=05b07db98892e58376d75e6412253728471245f4;hp=d3757a3f35ed843039e8c9f085f28a90386a9f3d;hb=7ddf1e9d70fba7aa25f425fc2812137f1328c62f;hpb=2159b8808998d2a75380ef6339147e48a39e3bae

diff --git a/src/win32_replacements.c b/src/win32_replacements.c
index d3757a3f..05b07db9 100644
--- a/src/win32_replacements.c
+++ b/src/win32_replacements.c
@@ -4,22 +4,20 @@
  */
 
 /*
- * Copyright (C) 2013 Eric Biggers
+ * Copyright (C) 2013-2016 Eric Biggers
  *
- * This file is part of wimlib, a library for working with WIM files.
+ * This file is free software; you can redistribute it and/or modify it under
+ * the terms of the GNU Lesser General Public License as published by the Free
+ * Software Foundation; either version 3 of the License, or (at your option) any
+ * later version.
  *
- * wimlib is free software; you can redistribute it and/or modify it under the
- * terms of the GNU General Public License as published by the Free
- * Software Foundation; either version 3 of the License, or (at your option)
- * any later version.
- *
- * wimlib is distributed in the hope that it will be useful, but WITHOUT ANY
- * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR
- * A PARTICULAR PURPOSE. See the GNU General Public License for more
+ * This file is distributed in the hope that it will be useful, but WITHOUT
+ * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
+ * FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more
  * details.
  *
- * You should have received a copy of the GNU General Public License
- * along with wimlib; if not, see http://www.gnu.org/licenses/.
+ * You should have received a copy of the GNU Lesser General Public License
+ * along with this file; if not, see http://www.gnu.org/licenses/.
  */
 
 #ifdef __WIN32__
@@ -30,15 +28,297 @@
 
 #include <errno.h>
 #include <pthread.h>
-#include <shlwapi.h> /* for PathMatchSpecW() */
+#include <io.h>	/* for _get_osfhandle()  */
+#include <fcntl.h>
+
 #include "wimlib/win32_common.h"
 
 #include "wimlib/assert.h"
-#include "wimlib/file_io.h"
 #include "wimlib/glob.h"
 #include "wimlib/error.h"
 #include "wimlib/util.h"
 
+static int
+win32_error_to_errno(DWORD err_code)
+{
+	/* This mapping is that used in Cygwin.
+	 * Some of these choices are arbitrary. */
+	switch (err_code) {
+	case ERROR_ACCESS_DENIED:
+		return EACCES;
+	case ERROR_ACTIVE_CONNECTIONS:
+		return EAGAIN;
+	case ERROR_ALREADY_EXISTS:
+		return EEXIST;
+	case ERROR_BAD_DEVICE:
+		return ENODEV;
+	case ERROR_BAD_EXE_FORMAT:
+		return ENOEXEC;
+	case ERROR_BAD_NETPATH:
+		return ENOENT;
+	case ERROR_BAD_NET_NAME:
+		return ENOENT;
+	case ERROR_BAD_NET_RESP:
+		return ENOSYS;
+	case ERROR_BAD_PATHNAME:
+		return ENOENT;
+	case ERROR_BAD_PIPE:
+		return EINVAL;
+	case ERROR_BAD_UNIT:
+		return ENODEV;
+	case ERROR_BAD_USERNAME:
+		return EINVAL;
+	case ERROR_BEGINNING_OF_MEDIA:
+		return EIO;
+	case ERROR_BROKEN_PIPE:
+		return EPIPE;
+	case ERROR_BUSY:
+		return EBUSY;
+	case ERROR_BUS_RESET:
+		return EIO;
+	case ERROR_CALL_NOT_IMPLEMENTED:
+		return ENOSYS;
+	case ERROR_CANNOT_MAKE:
+		return EPERM;
+	case ERROR_CHILD_NOT_COMPLETE:
+		return EBUSY;
+	case ERROR_COMMITMENT_LIMIT:
+		return EAGAIN;
+	case ERROR_CRC:
+		return EIO;
+	case ERROR_DEVICE_DOOR_OPEN:
+		return EIO;
+	case ERROR_DEVICE_IN_USE:
+		return EAGAIN;
+	case ERROR_DEVICE_REQUIRES_CLEANING:
+		return EIO;
+	case ERROR_DIRECTORY:
+		return ENOTDIR;
+	case ERROR_DIR_NOT_EMPTY:
+		return ENOTEMPTY;
+	case ERROR_DISK_CORRUPT:
+		return EIO;
+	case ERROR_DISK_FULL:
+		return ENOSPC;
+#ifdef ENOTUNIQ
+	case ERROR_DUP_NAME:
+		return ENOTUNIQ;
+#endif
+	case ERROR_EAS_DIDNT_FIT:
+		return ENOSPC;
+#ifdef ENOTSUP
+	case ERROR_EAS_NOT_SUPPORTED:
+		return ENOTSUP;
+#endif
+	case ERROR_EA_LIST_INCONSISTENT:
+		return EINVAL;
+	case ERROR_EA_TABLE_FULL:
+		return ENOSPC;
+	case ERROR_END_OF_MEDIA:
+		return ENOSPC;
+	case ERROR_EOM_OVERFLOW:
+		return EIO;
+	case ERROR_EXE_MACHINE_TYPE_MISMATCH:
+		return ENOEXEC;
+	case ERROR_EXE_MARKED_INVALID:
+		return ENOEXEC;
+	case ERROR_FILEMARK_DETECTED:
+		return EIO;
+	case ERROR_FILENAME_EXCED_RANGE:
+		return ENAMETOOLONG;
+	case ERROR_FILE_CORRUPT:
+		return EEXIST;
+	case ERROR_FILE_EXISTS:
+		return EEXIST;
+	case ERROR_FILE_INVALID:
+		return ENXIO;
+	case ERROR_FILE_NOT_FOUND:
+		return ENOENT;
+	case ERROR_HANDLE_DISK_FULL:
+		return ENOSPC;
+#ifdef ENODATA
+	case ERROR_HANDLE_EOF:
+		return ENODATA;
+#endif
+	case ERROR_INVALID_ADDRESS:
+		return EINVAL;
+	case ERROR_INVALID_AT_INTERRUPT_TIME:
+		return EINTR;
+	case ERROR_INVALID_BLOCK_LENGTH:
+		return EIO;
+	case ERROR_INVALID_DATA:
+		return EINVAL;
+	case ERROR_INVALID_DRIVE:
+		return ENODEV;
+	case ERROR_INVALID_EA_NAME:
+		return EINVAL;
+	case ERROR_INVALID_EXE_SIGNATURE:
+		return ENOEXEC;
+#ifdef EBADRQC
+	case ERROR_INVALID_FUNCTION:
+		return EBADRQC;
+#endif
+	case ERROR_INVALID_HANDLE:
+		return EBADF;
+	case ERROR_INVALID_NAME:
+		return ENOENT;
+	case ERROR_INVALID_PARAMETER:
+		return EINVAL;
+	case ERROR_INVALID_SIGNAL_NUMBER:
+		return EINVAL;
+	case ERROR_IOPL_NOT_ENABLED:
+		return ENOEXEC;
+	case ERROR_IO_DEVICE:
+		return EIO;
+	case ERROR_IO_INCOMPLETE:
+		return EAGAIN;
+	case ERROR_IO_PENDING:
+		return EAGAIN;
+	case ERROR_LOCK_VIOLATION:
+		return EBUSY;
+	case ERROR_MAX_THRDS_REACHED:
+		return EAGAIN;
+	case ERROR_META_EXPANSION_TOO_LONG:
+		return EINVAL;
+	case ERROR_MOD_NOT_FOUND:
+		return ENOENT;
+#ifdef EMSGSIZE
+	case ERROR_MORE_DATA:
+		return EMSGSIZE;
+#endif
+	case ERROR_NEGATIVE_SEEK:
+		return EINVAL;
+	case ERROR_NETNAME_DELETED:
+		return ENOENT;
+	case ERROR_NOACCESS:
+		return EFAULT;
+	case ERROR_NONE_MAPPED:
+		return EINVAL;
+	case ERROR_NONPAGED_SYSTEM_RESOURCES:
+		return EAGAIN;
+#ifdef ENOLINK
+	case ERROR_NOT_CONNECTED:
+		return ENOLINK;
+#endif
+	case ERROR_NOT_ENOUGH_MEMORY:
+		return ENOMEM;
+	case ERROR_NOT_OWNER:
+		return EPERM;
+#ifdef ENOMEDIUM
+	case ERROR_NOT_READY:
+		return ENOMEDIUM;
+#endif
+	case ERROR_NOT_SAME_DEVICE:
+		return EXDEV;
+	case ERROR_NOT_SUPPORTED:
+		return ENOSYS;
+	case ERROR_NO_DATA:
+		return EPIPE;
+	case ERROR_NO_DATA_DETECTED:
+		return EIO;
+#ifdef ENOMEDIUM
+	case ERROR_NO_MEDIA_IN_DRIVE:
+		return ENOMEDIUM;
+#endif
+#ifdef ENMFILE
+	case ERROR_NO_MORE_FILES:
+		return ENMFILE;
+#endif
+#ifdef ENMFILE
+	case ERROR_NO_MORE_ITEMS:
+		return ENMFILE;
+#endif
+	case ERROR_NO_MORE_SEARCH_HANDLES:
+		return ENFILE;
+	case ERROR_NO_PROC_SLOTS:
+		return EAGAIN;
+	case ERROR_NO_SIGNAL_SENT:
+		return EIO;
+	case ERROR_NO_SYSTEM_RESOURCES:
+		return EFBIG;
+	case ERROR_NO_TOKEN:
+		return EINVAL;
+	case ERROR_OPEN_FAILED:
+		return EIO;
+	case ERROR_OPEN_FILES:
+		return EAGAIN;
+	case ERROR_OUTOFMEMORY:
+		return ENOMEM;
+	case ERROR_PAGED_SYSTEM_RESOURCES:
+		return EAGAIN;
+	case ERROR_PAGEFILE_QUOTA:
+		return EAGAIN;
+	case ERROR_PATH_NOT_FOUND:
+		return ENOENT;
+	case ERROR_PIPE_BUSY:
+		return EBUSY;
+	case ERROR_PIPE_CONNECTED:
+		return EBUSY;
+#ifdef ECOMM
+	case ERROR_PIPE_LISTENING:
+		return ECOMM;
+	case ERROR_PIPE_NOT_CONNECTED:
+		return ECOMM;
+#endif
+	case ERROR_POSSIBLE_DEADLOCK:
+		return EDEADLOCK;
+	case ERROR_PRIVILEGE_NOT_HELD:
+		return EPERM;
+	case ERROR_PROCESS_ABORTED:
+		return EFAULT;
+	case ERROR_PROC_NOT_FOUND:
+		return ESRCH;
+#ifdef ENONET
+	case ERROR_REM_NOT_LIST:
+		return ENONET;
+#endif
+	case ERROR_SECTOR_NOT_FOUND:
+		return EINVAL;
+	case ERROR_SEEK:
+		return EINVAL;
+	case ERROR_SETMARK_DETECTED:
+		return EIO;
+	case ERROR_SHARING_BUFFER_EXCEEDED:
+		return ENOLCK;
+	case ERROR_SHARING_VIOLATION:
+		return EBUSY;
+	case ERROR_SIGNAL_PENDING:
+		return EBUSY;
+	case ERROR_SIGNAL_REFUSED:
+		return EIO;
+#ifdef ELIBBAD
+	case ERROR_SXS_CANT_GEN_ACTCTX:
+		return ELIBBAD;
+#endif
+	case ERROR_THREAD_1_INACTIVE:
+		return EINVAL;
+	case ERROR_TOO_MANY_LINKS:
+		return EMLINK;
+	case ERROR_TOO_MANY_OPEN_FILES:
+		return EMFILE;
+	case ERROR_WAIT_NO_CHILDREN:
+		return ECHILD;
+	case ERROR_WORKING_SET_QUOTA:
+		return EAGAIN;
+	case ERROR_WRITE_PROTECT:
+		return EROFS;
+	default:
+		return -1;
+	}
+}
+
+static void
+set_errno_from_win32_error(DWORD err)
+{
+	errno = win32_error_to_errno(err);
+}
+
+static void
+set_errno_from_GetLastError(void)
+{
+	set_errno_from_win32_error(GetLastError());
+}
+
 /* Replacement for POSIX fsync() */
 int
 fsync(int fd)
@@ -57,15 +337,26 @@ err:
 	return -1;
 }
 
-/* Use the Win32 API to get the number of processors */
+/* Use the Win32 API to get the number of processors.  */
 unsigned
-win32_get_number_of_processors(void)
+get_available_cpus(void)
 {
 	SYSTEM_INFO sysinfo;
 	GetSystemInfo(&sysinfo);
 	return sysinfo.dwNumberOfProcessors;
 }
 
+/* Use the Win32 API to get the amount of available memory.  */
+u64
+get_available_memory(void)
+{
+	MEMORYSTATUSEX status = {
+		.dwLength = sizeof(status),
+	};
+	GlobalMemoryStatusEx(&status);
+	return (u64)min(status.ullTotalPhys, status.ullTotalVirtual) * 85 / 100;
+}
+
 /* Replacement for POSIX-2008 realpath().  Warning: partial functionality only
  * (resolved_path must be NULL).   Also I highly doubt that GetFullPathName
  * really does the right thing under all circumstances. */
@@ -88,7 +379,7 @@ realpath(const wchar_t *path, wchar_t *resolved_path)
 	ret = GetFullPathNameW(path, ret, resolved_path, NULL);
 	if (!ret) {
 		err = GetLastError();
-		free(resolved_path);
+		FREE(resolved_path);
 		resolved_path = NULL;
 		goto fail_win32;
 	}
@@ -177,51 +468,10 @@ err_set_errno:
 	return -1;
 }
 
-/* Replacement for POSIX fnmatch() (partial functionality only) */
-int
-fnmatch(const wchar_t *pattern, const wchar_t *string, int flags)
-{
-	if (PathMatchSpecW(string, pattern))
-		return 0;
-	else
-		return FNM_NOMATCH;
-}
-
-/* truncate() replacement */
-int
-win32_truncate_replacement(const wchar_t *path, off_t size)
-{
-	DWORD err = NO_ERROR;
-	LARGE_INTEGER liOffset;
-
-	HANDLE h = win32_open_existing_file(path, GENERIC_WRITE);
-	if (h == INVALID_HANDLE_VALUE)
-		goto fail;
-
-	liOffset.QuadPart = size;
-	if (!SetFilePointerEx(h, liOffset, NULL, FILE_BEGIN))
-		goto fail_close_handle;
-
-	if (!SetEndOfFile(h))
-		goto fail_close_handle;
-	CloseHandle(h);
-	return 0;
-
-fail_close_handle:
-	err = GetLastError();
-	CloseHandle(h);
-fail:
-	if (err == NO_ERROR)
-		err = GetLastError();
-	set_errno_from_win32_error(err);
-	return -1;
-}
-
-
 /* This really could be replaced with _wcserror_s, but this doesn't seem to
  * actually be available in MSVCRT.DLL on Windows XP (perhaps it's statically
  * linked in by Visual Studio...?). */
-extern int
+int
 win32_strerror_r_replacement(int errnum, wchar_t *buf, size_t buflen)
 {
 	static pthread_mutex_t strerror_lock = PTHREAD_MUTEX_INITIALIZER;
@@ -243,20 +493,24 @@ do_pread_or_pwrite(int fd, void *buf, size_t count, off_t offset,
 	LARGE_INTEGER relative_offset;
 	OVERLAPPED overlapped;
 	BOOL bret;
+	DWORD err = 0;
 
 	h = (HANDLE)_get_osfhandle(fd);
 	if (h == INVALID_HANDLE_VALUE)
-		goto err;
+		goto error;
 
 	if (GetFileType(h) == FILE_TYPE_PIPE) {
 		errno = ESPIPE;
-		goto err;
+		goto error;
 	}
 
 	/* Get original position */
 	relative_offset.QuadPart = 0;
-	if (!SetFilePointerEx(h, relative_offset, &orig_offset, FILE_CURRENT))
-		goto err_set_errno;
+	if (!SetFilePointerEx(h, relative_offset, &orig_offset, FILE_CURRENT)) {
+		err = GetLastError();
+		win32_error(err, L"Failed to get original file position");
+		goto error;
+	}
 
 	memset(&overlapped, 0, sizeof(overlapped));
 	overlapped.Offset = offset;
@@ -267,17 +521,26 @@ do_pread_or_pwrite(int fd, void *buf, size_t count, off_t offset,
 		bret = WriteFile(h, buf, count, &bytes_read_or_written, &overlapped);
 	else
 		bret = ReadFile(h, buf, count, &bytes_read_or_written, &overlapped);
-	if (!bret)
-		goto err_set_errno;
+	if (!bret) {
+		err = GetLastError();
+		win32_error(err, L"Failed to %s %zu bytes at offset %"PRIu64,
+			    (is_pwrite ? "write" : "read"), count, offset);
+		goto error;
+	}
 
 	/* Restore the original position */
-	if (!SetFilePointerEx(h, orig_offset, NULL, FILE_BEGIN))
-		goto err_set_errno;
+	if (!SetFilePointerEx(h, orig_offset, NULL, FILE_BEGIN)) {
+		err = GetLastError();
+		win32_error(err, L"Failed to restore file position to %"PRIu64,
+			    offset);
+		goto error;
+	}
 
 	return bytes_read_or_written;
-err_set_errno:
-	set_errno_from_GetLastError();
-err:
+
+error:
+	if (err)
+		set_errno_from_win32_error(err);
 	return -1;
 }
 
@@ -299,61 +562,6 @@ pwrite(int fd, const void *buf, size_t count, off_t offset)
 	return do_pread_or_pwrite(fd, (void*)buf, count, offset, true);
 }
 
-/* Dumb Windows implementation of writev().  It writes the vectors one at a
- * time. */
-ssize_t writev(int fd, const struct iovec *iov, int iovcnt)
-{
-	ssize_t total_bytes_written = 0;
-
-	if (iovcnt <= 0) {
-		errno = EINVAL;
-		return -1;
-	}
-	for (int i = 0; i < iovcnt; i++) {
-		ssize_t bytes_written;
-
-		bytes_written = write(fd, iov[i].iov_base, iov[i].iov_len);
-		if (bytes_written >= 0)
-			total_bytes_written += bytes_written;
-		if (bytes_written != iov[i].iov_len) {
-			if (total_bytes_written == 0)
-				total_bytes_written = -1;
-			break;
-		}
-	}
-	return total_bytes_written;
-}
-
-int
-win32_get_file_and_vol_ids(const wchar_t *path, u64 *ino_ret, u64 *dev_ret)
-{
-	HANDLE h;
-	BY_HANDLE_FILE_INFORMATION file_info;
-	int ret;
-	DWORD err;
-
-	h = win32_open_existing_file(path, FILE_READ_ATTRIBUTES);
-	if (h == INVALID_HANDLE_VALUE) {
-		ret = WIMLIB_ERR_OPEN;
-		goto out;
-	}
-
-	if (!GetFileInformationByHandle(h, &file_info)) {
-		ret = WIMLIB_ERR_STAT;
-	} else {
-		*ino_ret = ((u64)file_info.nFileIndexHigh << 32) |
-			    (u64)file_info.nFileIndexLow;
-		*dev_ret = file_info.dwVolumeSerialNumber;
-		ret = 0;
-	}
-	err = GetLastError();
-	CloseHandle(h);
-	SetLastError(err);
-out:
-	set_errno_from_GetLastError();
-	return ret;
-}
-
 /* Replacement for glob() in Windows native builds that operates on wide
  * characters.  */
 int
@@ -366,6 +574,7 @@ win32_wglob(const wchar_t *pattern, int flags,
 	HANDLE hFind;
 	int ret;
 	size_t nspaces;
+	int errno_save;
 
 	const wchar_t *backslash, *end_slash;
 	size_t prefix_len;
@@ -395,9 +604,7 @@ win32_wglob(const wchar_t *pattern, int flags,
 			errno = 0;
 			return GLOB_NOMATCH;
 		} else {
-			/* The other possible error codes for FindFirstFile()
-			 * are undocumented. */
-			errno = EIO;
+			set_errno_from_win32_error(err);
 			return GLOB_ABORTED;
 		}
 	}
@@ -431,22 +638,21 @@ win32_wglob(const wchar_t *pattern, int flags,
 	} while (FindNextFileW(hFind, &dat));
 	err = GetLastError();
 	CloseHandle(hFind);
-	if (err == ERROR_NO_MORE_FILES) {
-		errno = 0;
-		return 0;
-	} else {
-		/* Other possible error codes for FindNextFile() are
-		 * undocumented */
-		errno = EIO;
+	if (err != ERROR_NO_MORE_FILES) {
+		set_errno_from_win32_error(err);
 		ret = GLOB_ABORTED;
 		goto fail_globfree;
 	}
+	return 0;
+
 oom:
 	CloseHandle(hFind);
 	errno = ENOMEM;
 	ret = GLOB_NOSPACE;
 fail_globfree:
+	errno_save = errno;
 	globfree(pglob);
+	errno = errno_save;
 	return ret;
 }
 
@@ -455,8 +661,37 @@ globfree(glob_t *pglob)
 {
 	size_t i;
 	for (i = 0; i < pglob->gl_pathc; i++)
-		free(pglob->gl_pathv[i]);
-	free(pglob->gl_pathv);
+		FREE(pglob->gl_pathv[i]);
+	FREE(pglob->gl_pathv);
+}
+
+/* Replacement for fopen(path, "a") that doesn't prevent other processes from
+ * reading the file  */
+FILE *
+win32_open_logfile(const wchar_t *path)
+{
+	HANDLE h;
+	int fd;
+	FILE *fp;
+
+	h = CreateFile(path, FILE_APPEND_DATA, FILE_SHARE_VALID_FLAGS,
+		       NULL, OPEN_ALWAYS, 0, NULL);
+	if (h == INVALID_HANDLE_VALUE)
+		return NULL;
+
+	fd = _open_osfhandle((intptr_t)h, O_APPEND);
+	if (fd < 0) {
+		CloseHandle(h);
+		return NULL;
+	}
+
+	fp = fdopen(fd, "a");
+	if (!fp) {
+		close(fd);
+		return NULL;
+	}
+
+	return fp;
 }
 
 #endif /* __WIN32__ */