/*

  * Copyright (C) 2011  J. Ali Harlow <ali@juiblex.co.uk>

  *

  * This program 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 2 of the License, or

  * (at your option) any later version.

  *

  * This program 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 details.

  *

  * You should have received a copy of the GNU General Public License along

  * with this program; if not, write to the Free Software Foundation, Inc.,

  * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.

  */

 #include "config.h"

 #include <stdlib.h>

 #ifdef MSWIN_API

 #include <windows.h>

 #endif

 #include <stdio.h>

 #include <limits.h>

 #include <errno.h>

 #include <unistd.h>

 #include <fcntl.h>

 #include <sys/stat.h>

 #include <string.h>

 #include <assert.h>

 #if HAVE_WINDOWS_KTM

 #include <wchar.h>

 #include <ktmw32.h>

 #endif

 #include "razor.h"

 #include "razor-internal.h"

 /*

  * Atomic transactions

  */

 #ifndef O_BINARY

 #define O_BINARY	0

 #endif

 #define RAZOR_ASCII_ISALPHA(c)	\

 			((c) >= 'A' && (c) <= 'Z' || (c) >= 'a' && (c) <= 'z')

 static int allow_all_root_names = 0;

 /*

  * Primarily intended for testing named roots under UNIX platforms.

  */

 RAZOR_EXPORT void

 razor_disable_root_name_checks(int disable)

 {

 	allow_all_root_names = disable;

 }

 #ifdef MSWIN_API

 static char *

 razor_utf16_to_utf8(const wchar_t *utf16, int len)

 {

 	int n;

 	char *utf8;

 	n = WideCharToMultiByte(CP_UTF8, 0, utf16, len, NULL, 0, NULL, NULL);

 	if (len >= 0 && utf16[len])

 		n++;

 	utf8 = malloc(n);

 	(void)WideCharToMultiByte(CP_UTF8, 0, utf16, len, utf8, n, NULL, NULL);

 	if (len >= 0 && utf16[len])

 		utf8[n - 1] = 0;

 	return utf8;

 }

 static wchar_t *

 razor_utf8_to_utf16(const char *utf8, int len)

 {

 	int n;

 	wchar_t *utf16;

 	n = MultiByteToWideChar(CP_UTF8, 0, utf8, len, NULL, 0);

 	if (len >= 0 && utf8[len])

 		n++;

 	utf16 = malloc(n * sizeof(wchar_t));

 	(void)MultiByteToWideChar(CP_UTF8, 0, utf8, len, utf16, n);

 	if (len >= 0 && utf8[len])

 		utf16[n - 1] = 0;

 	return utf16;

 }

 #endif	/* MSWIN_API */

 #if HAVE_WINDOWS_KTM

 static int

 razor_valid_root_name(const wchar_t *name)

 {

 	if (allow_all_root_names)

 		return !wcschr(name, '/');

 	return RAZOR_ASCII_ISALPHA(name[0]) && name[1] == ':' &&

 	       name[2] == '\0';

 }

 struct razor_atomic {

 	HANDLE transaction;

 	int n_files;

 	struct razor_atomic_file {

 		wchar_t *path;

 		HANDLE h;

 	} *files;

 	char *error_path;

 	char *error_str;

 	char *error_msg;

 };

 struct razor_wstr {

 	wchar_t *str;

 	int len, allocated;

 };

 static struct razor_wstr *

 razor_wstr_create(const char *init, int len)

 {

 	int n;

 	struct razor_wstr *wstr;

 	wstr = malloc(sizeof(struct razor_wstr));

 	n = MultiByteToWideChar(CP_UTF8, 0, init, len, NULL, 0);

 	if (len >= 0 && init[len])

 		wstr->len = n++;

 	else

 		wstr->len = n - 1;

 	wstr->allocated = n * 2;

 	wstr->str = malloc(wstr->allocated * sizeof(wchar_t));

 	if (!wstr->str) {

 		free(wstr);

 		return NULL;

 	}

 	(void)MultiByteToWideChar(CP_UTF8, 0, init, len, wstr->str, n);

 	if (len >= 0 && init[len])

 		wstr->str[wstr->len] = 0;

 	return wstr;

 }

 static int

 razor_wstr_append(struct razor_wstr *wstr, const char *s, int len)

 {

 	int n, allocated;

 	wchar_t *str;

 	n = MultiByteToWideChar(CP_UTF8, 0, s, len, NULL, 0);

 	if (len < 0 || !s[len])

 		n--;

 	if (wstr->allocated <= wstr->len + n) {

 		allocated = (wstr->len + n + 1) * 2;

 		str = realloc(wstr->str, allocated * sizeof(wchar_t));

 		if (!str)

 			return -1;

 		wstr->allocated = allocated;

 		wstr->str = str;

 	}

 	(void)MultiByteToWideChar(CP_UTF8, 0, s, len, wstr->str + wstr->len, n);

 	wstr->len += n;

 	wstr->str[wstr->len] = 0;

 	return 0;

 }

 static void

 razor_wstr_destroy(struct razor_wstr *wstr)

 {

 	free(wstr->str);

 	free(wstr);

 }

 RAZOR_EXPORT struct razor_atomic *

 razor_atomic_open(const char *description)

 {

 	wchar_t *buf;

 	struct razor_atomic *atomic;

 	atomic = zalloc(sizeof *atomic);

 	buf = razor_utf8_to_utf16(description, -1);

 	atomic->transaction = CreateTransaction(NULL, 0,

 						TRANSACTION_DO_NOT_PROMOTE,

 						0, 0, 0, buf);

 	free(buf);

 	return atomic;

 }

 static void

 razor_atomic_set_error_str(struct razor_atomic *atomic, const wchar_t *path,

 			   const char *str)

 {

 	assert(!atomic->error_str);

 	free(atomic->error_path);

 	if (path)

 		atomic->error_path = razor_utf16_to_utf8(path, -1);

 	else

 		atomic->error_path = NULL;

 	atomic->error_str = strdup(str);

 }

 static void

 razor_atomic_set_error(struct razor_atomic *atomic, const wchar_t *path,

 		       DWORD error)

 {

 	wchar_t *buf;

 	assert(!atomic->error_str);

 	free(atomic->error_path);

 	if (path)

 		atomic->error_path = razor_utf16_to_utf8(path, -1);

 	else

 		atomic->error_path = NULL;

 	FormatMessageW(FORMAT_MESSAGE_ALLOCATE_BUFFER|

 		       FORMAT_MESSAGE_FROM_SYSTEM|FORMAT_MESSAGE_IGNORE_INSERTS,

 		       NULL, error, MAKELANGID(LANG_NEUTRAL,SUBLANG_DEFAULT),

 		       (LPWSTR)&buf, 0, NULL);

 	atomic->error_str = razor_utf16_to_utf8(buf, -1);

 	LocalFree(buf);

 }

 RAZOR_EXPORT int

 razor_atomic_commit(struct razor_atomic *atomic)

 {

 	int retval;

 	if (atomic->error_str)

 		return -1;

 	retval = !CommitTransaction(atomic->transaction);

 	if (retval) {

 		razor_atomic_set_error(atomic, NULL, GetLastError());

 		RollbackTransaction(atomic->transaction);

 	}

 	CloseHandle(atomic->transaction);

 	atomic->transaction = INVALID_HANDLE_VALUE;

 	return retval;

 }

 RAZOR_EXPORT void

 razor_atomic_destroy(struct razor_atomic *atomic)

 {

 	int i;

 	for(i = 0; i < atomic->n_files; i++) {

 		if (atomic->files[i].h != INVALID_HANDLE_VALUE) {

 			CloseHandle(atomic->files[i].h);

 			free(atomic->files[i].path);

 		}

 	}

 	free(atomic->files);

 	if (atomic->transaction != INVALID_HANDLE_VALUE) {

 		RollbackTransaction(atomic->transaction);

 		CloseHandle(atomic->transaction);

 	}

 	free(atomic->error_path);

 	free(atomic->error_str);

 	free(atomic->error_msg);

 	free(atomic);

 }

 RAZOR_EXPORT int

 razor_atomic_make_dirs(struct razor_atomic *atomic, const char *root,

 		       const char *path)

 {

 	struct razor_wstr *buffer;

 	const char *slash, *s, *next;

 	WIN32_FILE_ATTRIBUTE_DATA fa;

 	DWORD err;

 	int r, creating = 0;

 	if (atomic->error_str)

 		return -1;

 	buffer = razor_wstr_create(root, -1);

 	slash = path;

 	for (; *slash != '\0'; slash = next) {

 		next = strpbrk(slash + 1, "/\\");

 		if (next == NULL)

 			break;

 		razor_wstr_append(buffer, slash, next - slash);

 		if (!creating) {

 			if (razor_valid_root_name(buffer->str))

 				continue;

 			r = GetFileAttributesTransactedW(buffer->str,

 							 GetFileExInfoStandard,

 							 &fa,

 							 atomic->transaction);

 			if (!r) {

 				err = GetLastError();

 				if (err == ERROR_FILE_NOT_FOUND) {

 					creating = 1;

 				} else {

 					razor_atomic_set_error(atomic,

 							       buffer->str,

 							       err);

 					razor_wstr_destroy(buffer);

 					return -1;

 				}

 			} else if (!(fa.dwFileAttributes&

 				     FILE_ATTRIBUTE_DIRECTORY)) {

 				razor_atomic_set_error_str(atomic, buffer->str,

 							   "Not a directory");

 				razor_wstr_destroy(buffer);

 				return -1;

 			}

 		}

 		if (creating) {

 			if (!CreateDirectoryTransactedW(NULL, buffer->str, NULL,

 							atomic->transaction)) {

 				razor_atomic_set_error(atomic, buffer->str,

 						       GetLastError());

 				razor_wstr_destroy(buffer);

 				return -1;

 			}

 			/* FIXME: What to do about permissions for dirs we

 			 * have to create but are not in the cpio archive? */

 		}

 	}

 	razor_wstr_destroy(buffer);

 	return 0;

 }

 RAZOR_EXPORT int

 razor_atomic_remove(struct razor_atomic *atomic, const char *path)

 {

 	wchar_t *buf;

 	DWORD err;

 	if (atomic->error_str)

 		return -1;

 	buf = razor_utf8_to_utf16(path, -1);

 	if (DeleteFileTransactedW(buf, atomic->transaction)) {

 		free(buf);

 		return 0;

 	}

 	err = GetLastError();

 	if (err == ERROR_FILE_NOT_FOUND || err == ERROR_PATH_NOT_FOUND) {

 		free(buf);

 		return 0;

 	}

 	if (SetFileAttributesTransactedW(buf, FILE_ATTRIBUTE_NORMAL,

 					 atomic->transaction)) {

 		if (DeleteFileTransactedW(buf, atomic->transaction)) {

 			free(buf);

 			return 0;

 		}

 		err = GetLastError();

 	}

 	if (RemoveDirectoryTransactedW(buf, atomic->transaction) ||

 	    GetLastError() == ERROR_DIR_NOT_EMPTY) {

 		free(buf);

 		return 0;

 	}

 	/*

 	 * It would be tempting to use:

 	 * 	MoveFileEx(path, NULL, MOVEFILE_DELAY_UNTIL_REBOOT)

 	 * but unless we can guarantee that the system will be rebooted

 	 * before we (or some other application) write another file with the

 	 * same path, this is likely to cause more problems than it solves.

 	 */

 	razor_atomic_set_error(atomic, buf, err);

 	free(buf);

 	return -1;

 }

 RAZOR_EXPORT int

 razor_atomic_rename_file(struct razor_atomic *atomic, const char *oldpath,

 			 const char *newpath)

 {

 	wchar_t *oldbuf, *newbuf;

 	const DWORD flags = MOVEFILE_COPY_ALLOWED | MOVEFILE_REPLACE_EXISTING;

 	if (atomic->error_str)

 		return -1;

 	newbuf = razor_utf8_to_utf16(newpath, -1);

 	oldbuf = razor_utf8_to_utf16(oldpath, -1);

 	/*

 	 * Passing MOVEFILE_REPLACE_EXISTING to MoveFileTransaction() will

 	 * cover every case we care about _except_ replacing an empty

 	 * directory with a file. Calling RemoveDirectoryTransacted() will deal

 	 * with this case while having no effect in all other cases.

 	 */

 	(void)RemoveDirectoryTransactedW(newbuf, atomic->transaction);

 	if (!MoveFileTransactedW(oldbuf, newbuf, NULL, NULL, flags,

 			         atomic->transaction))

 		razor_atomic_set_error(atomic, newbuf, GetLastError());

 	free(newbuf);

 	free(oldbuf);

 	return !!atomic->error_str;

 }

 RAZOR_EXPORT int

 razor_atomic_create_dir(struct razor_atomic *atomic, const char *dirname,

 			mode_t mode)

 {

 	wchar_t *buf;

 	DWORD err;

 	WIN32_FILE_ATTRIBUTE_DATA fa;

 	if (atomic->error_str)

 		return -1;

 	buf = razor_utf8_to_utf16(dirname, -1);

 	if (!CreateDirectoryTransactedW(NULL, buf, NULL, atomic->transaction)) {

 		err = GetLastError();

 		if (err != ERROR_FILE_EXISTS && err != ERROR_ALREADY_EXISTS) {

 abort:

 			razor_atomic_set_error(atomic, buf, err);

 			free(buf);

 			return -1;

 		}

 		if (!GetFileAttributesTransactedW(buf, GetFileExInfoStandard,

 						  &fa, atomic->transaction))

 			goto abort;

 		if (!(fa.dwFileAttributes&FILE_ATTRIBUTE_DIRECTORY)) {

 			if (razor_atomic_remove(atomic, dirname)) {

 				free(buf);

 				return -1;

 			}

 			if (!CreateDirectoryTransactedW(NULL, buf, NULL,

 							atomic->transaction)) {

 				err = GetLastError();

 				goto abort;

 			}

 		}

 	}

 	free(buf);

 	return 0;

 }

 RAZOR_EXPORT int

 razor_atomic_create_symlink(struct razor_atomic *atomic, const char *target,

 			    const char *path)

 {

 	if (atomic->error_str)

 		return -1;

 	/*

 	 * This isn't true, but symbolic links under Windows 7

 	 * need to know whether the target is a directory or not

 	 * and we don't always know that at the time when the

 	 * link is created, so it's a convienent lie for now.

 	 */

 	razor_atomic_set_error_str(atomic, NULL, "Symbolic links not supported "

 						 "on this platform");

 	return -1;

 }

 RAZOR_EXPORT int

 razor_atomic_create_file(struct razor_atomic *atomic, const char *filename,

 			 mode_t mode)

 {

 	DWORD attribs;

 	struct razor_atomic_file *files;

 	int i = atomic->n_files;

 	if (atomic->error_str)

 		return -1;

 	files = realloc(atomic->files,

 			(atomic->n_files+1) * sizeof(struct razor_atomic_file));

 	if (!files) {

 		razor_atomic_set_error_str(atomic, NULL, "Not enough memory");

 		return -1;

 	}

 	atomic->n_files++;

 	atomic->files = files;

 	files[i].path = razor_utf8_to_utf16(filename, -1);

 	/*

 	 * Passing CREATE_ALWAYS to CreateFileTransacted() will cover

 	 * every case we care about _except_ replacing an empty directory

 	 * with a file. Calling RemoveDirectoryTransacted() will deal

 	 * with this case while having no effect in all other cases.

 	 */

 	(void)RemoveDirectoryTransactedW(files[i].path, atomic->transaction);

 	if (mode & S_IWUSR)

 		attribs = FILE_ATTRIBUTE_NORMAL;

 	else

 		attribs = FILE_ATTRIBUTE_READONLY;

 	files[i].h = CreateFileTransactedW(files[i].path, GENERIC_WRITE,

 					   0, NULL, CREATE_ALWAYS, attribs,

 					   NULL, atomic->transaction, NULL,

 					   NULL);

 	if (files[i].h == INVALID_HANDLE_VALUE) {

 		razor_atomic_set_error(atomic, files[i].path, GetLastError());

 		free(files[i].path);

 		atomic->n_files--;

 		return -1;

 	}

 	return i;

 }

 RAZOR_EXPORT int

 razor_atomic_write(struct razor_atomic *atomic, int handle, const void *data,

 		   size_t size)

 {

 	DWORD written;

 	if (atomic->error_str)

 		return -1;

 	assert(handle < atomic->n_files);

 	assert(atomic->files[handle].h != INVALID_HANDLE_VALUE);

 	while(size) {

 		if (!WriteFile(atomic->files[handle].h, data, size, &written,

 			       NULL)) {

 			razor_atomic_set_error(atomic,

 					       atomic->files[handle].path,

 					       GetLastError());

 			(void)CloseHandle(atomic->files[handle].h);

 			free(atomic->files[handle].path);

 			atomic->files[handle].path = NULL;

 			atomic->files[handle].h = INVALID_HANDLE_VALUE;

 			return -1;

 		}

 		data += written;

 		size -= written;

 	}

 	return 0;

 }

 RAZOR_EXPORT int

 razor_atomic_sync(struct razor_atomic *atomic, int handle)

 {

 	HANDLE h;

 	if (atomic->error_str)

 		return -1;

 	assert(handle < atomic->n_files);

 	assert(atomic->files[handle].h != INVALID_HANDLE_VALUE);

 	if (!CloseHandle(atomic->files[handle].h)) {

 		razor_atomic_set_error(atomic, atomic->files[handle].path,

 				       GetLastError());

 		free(atomic->files[handle].path);

 		atomic->files[handle].path = NULL;

 		atomic->files[handle].h = INVALID_HANDLE_VALUE;

 		return -1;

 	}

 	h = CreateFileTransactedW(atomic->files[handle].path, GENERIC_WRITE, 0,

 				  NULL, OPEN_EXISTING, 0, NULL,

 				  atomic->transaction, NULL, NULL);

 	atomic->files[handle].h = h;

 	if (atomic->files[handle].h == INVALID_HANDLE_VALUE) {

 		razor_atomic_set_error(atomic, atomic->files[handle].path,

 				       GetLastError());

 		free(atomic->files[handle].path);

 		atomic->files[handle].path = NULL;

 		return -1;

 	}

 	return !!atomic->error_str;

 }

 RAZOR_EXPORT int

 razor_atomic_close(struct razor_atomic *atomic, int handle)

 {

 	if (atomic->error_str)

 		return -1;

 	assert(handle < atomic->n_files);

 	assert(atomic->files[handle].h != INVALID_HANDLE_VALUE);

 	if (!CloseHandle(atomic->files[handle].h))

 		razor_atomic_set_error(atomic, atomic->files[handle].path,

 				       GetLastError());

 	free(atomic->files[handle].path);

 	atomic->files[handle].path = NULL;

 	atomic->files[handle].h = INVALID_HANDLE_VALUE;

 	while(atomic->n_files > 0 &&

 	      atomic->files[atomic->n_files-1].h == INVALID_HANDLE_VALUE)

 		atomic->n_files--;

 	return !!atomic->error_str;

 }

 #else		/* HAVE_WINDOWS_KVM */

 static int

 razor_valid_root_name(const char *name)

 {

 	if (allow_all_root_names) {

 #ifdef MSWIN_API

 		return !strpbrk(name, "/\\");

 #else

 		return !strchr(name, '/');

 #endif

 	}

 #ifdef MSWIN_API

 	return RAZOR_ASCII_ISALPHA(name[0]) && name[1] == ':' &&

 	       name[2] == '\0';

 #else

 	return name[0] == '\0';

 #endif

 }

 struct razor_atomic {

 	char *error_path;

 	char *error_str;

 	char *error_msg;

 };

 RAZOR_EXPORT struct razor_atomic *

 razor_atomic_open(const char *description)

 {

 	struct razor_atomic *atomic;

 	atomic = zalloc(sizeof *atomic);

 	return atomic;

 }

 static void

 razor_atomic_set_error_str(struct razor_atomic *atomic, const char *path,

 			   const char *str)

 {

 	assert(!atomic->error_str);

 	atomic->error_path = path ? strdup(path) : NULL;

 	atomic->error_str = strdup(str);

 }

 #ifdef MSWIN_API

 static void

 razor_atomic_set_error_mswin(struct razor_atomic *atomic, const wchar_t *path,

 		       DWORD error)

 {

 	wchar_t *buf;

 	assert(!atomic->error_str);

 	free(atomic->error_path);

 	if (path)

 		atomic->error_path = razor_utf16_to_utf8(path, -1);

 	else

 		atomic->error_path = NULL;

 	FormatMessageW(FORMAT_MESSAGE_ALLOCATE_BUFFER|

 		       FORMAT_MESSAGE_FROM_SYSTEM|FORMAT_MESSAGE_IGNORE_INSERTS,

 		       NULL, error, MAKELANGID(LANG_NEUTRAL,SUBLANG_DEFAULT),

 		       (LPWSTR)&buf, 0, NULL);

 	atomic->error_str = razor_utf16_to_utf8(buf, -1);

 	LocalFree(buf);

 }

 #endif

 RAZOR_EXPORT int

 razor_atomic_commit(struct razor_atomic *atomic)

 {

 	return !!atomic->error_str;

 }

 RAZOR_EXPORT void

 razor_atomic_destroy(struct razor_atomic *atomic)

 {

 	free(atomic->error_path);

 	free(atomic->error_str);

 	free(atomic->error_msg);

 	free(atomic);

 }

 RAZOR_EXPORT int

 razor_atomic_make_dirs(struct razor_atomic *atomic, const char *root,

 		       const char *path)

 {

 	char buffer[PATH_MAX], *p;

 	const char *slash, *next;

 	struct stat buf;

 	if (atomic->error_str)

 		return -1;

 	strcpy(buffer, root);

 	p = buffer + strlen(buffer);

 	slash = path;

 	for (slash = path; *slash != '\0'; slash = next) {

 #ifdef MSWIN_API

 		next = strpbrk(slash + 1, "/\\");

 #else

 		next = strchr(slash + 1, '/');

 #endif

 		if (next == NULL)

 			break;

 		memcpy(p, slash, next - slash);

 		p += next - slash;

 		*p = '\0';

 		if (razor_valid_root_name(buffer))

 			continue;

 		if (stat(buffer, &buf) == 0) {

 			if (!S_ISDIR(buf.st_mode)) {

 				razor_atomic_set_error_str(atomic, buffer,

 							   "Not a directory");

 				return -1;

 			}

 		} else if (mkdir(buffer, 0777) < 0) {

 			razor_atomic_set_error_str(atomic, buffer,

 						   strerror(errno));

 			return -1;

 		}

 	}

 	return 0;

 }

 RAZOR_EXPORT int

 razor_atomic_remove(struct razor_atomic *atomic, const char *path)

 {

 #ifdef MSWIN_API

 	wchar_t *buf;

 	DWORD err;

 #endif

 	if (atomic->error_str)

 		return -1;

 #ifdef MSWIN_API

 	buf = razor_utf8_to_utf16(path, -1);

 	if (!DeleteFileW(buf)) {

 		err = GetLastError();

 		if (err != ERROR_FILE_NOT_FOUND &&

 		    err != ERROR_PATH_NOT_FOUND &&

 		    !(SetFileAttributesW(buf, FILE_ATTRIBUTE_NORMAL) &&

 		      DeleteFileW(buf)) &&

 		    !RemoveDirectoryW(buf) &&

 		    GetLastError() != ERROR_DIR_NOT_EMPTY)

 			razor_atomic_set_error_mswin(atomic, buf, err);

 	}

 	free(buf);

 #else

 	if (remove(path))

 		razor_atomic_set_error_str(atomic, path, strerror(errno));

 #endif

 	return !!atomic->error_str;

 }

 RAZOR_EXPORT int

 razor_atomic_rename_file(struct razor_atomic *atomic, const char *oldpath,

 			 const char *newpath)

 {

 #ifdef MSWIN_API

 	wchar_t *oldbuf, *newbuf;

 	const DWORD flags = MOVEFILE_COPY_ALLOWED | MOVEFILE_REPLACE_EXISTING;

 #endif

 	if (atomic->error_str)

 		return -1;

 #ifdef MSWIN_API

 	newbuf = razor_utf8_to_utf16(newpath, -1);

 	oldbuf = razor_utf8_to_utf16(oldpath, -1);

 	/*

 	 * Passing MOVEFILE_REPLACE_EXISTING to MoveFileEx() will

 	 * cover every case we care about _except_ replacing an empty

 	 * directory with a file. Calling RemoveDirectory() will deal

 	 * with this case while having no effect in all other cases.

 	 */

 	(void)RemoveDirectoryW(newbuf);

 	if (!MoveFileExW(oldbuf, newbuf, flags))

 		razor_atomic_set_error_mswin(atomic, newbuf, GetLastError());

 	free(newbuf);

 	free(oldbuf);

 #else

 	if (rename(oldpath, newpath))

 		razor_atomic_set_error_str(atomic, newpath, strerror(errno));

 #endif

 	return !!atomic->error_str;

 }

 RAZOR_EXPORT int

 razor_atomic_create_dir(struct razor_atomic *atomic, const char *dirname,

 			mode_t mode)

 {

 	if (atomic->error_str)

 		return -1;

 	if (!mkdir(dirname, mode & (S_IRWXU | S_IRWXG | S_IRWXO)))

 		return 0;

 	if (errno != EEXIST) {

 		razor_atomic_set_error_str(atomic, dirname, strerror(errno));

 		return -1;

 	}

 	if (chmod(dirname, mode & (S_IRWXU | S_IRWXG | S_IRWXO)) < 0) {

 		razor_atomic_set_error_str(atomic, dirname, strerror(errno));

 		return -1;

 	}

 	return 0;

 }

 RAZOR_EXPORT int

 razor_atomic_create_symlink(struct razor_atomic *atomic, const char *target,

 			    const char *path)

 {

 	if (atomic->error_str)

 		return -1;

 #if HAVE_SYMLINK

 	if (symlink(target, path) < 0) {

 		razor_atomic_set_error_str(atomic, NULL, strerror(errno));

 		return -1;

 	}

 #else

 	razor_atomic_set_error_str(atomic, NULL, "Symbolic links not supported "

 						 "on this platform");

 #endif

 	return 0;

 }

 RAZOR_EXPORT int

 razor_atomic_create_file(struct razor_atomic *atomic, const char *filename,

 			 mode_t mode)

 {

 	int fd;

 	if (atomic->error_str)

 		return -1;

 	atomic->error_path = strdup(filename);

 	fd = open(atomic->error_path, O_WRONLY | O_CREAT | O_TRUNC | O_BINARY,

 		  mode & (S_IRWXU | S_IRWXG | S_IRWXO));

 	if (fd == -1)

 		razor_atomic_set_error_str(atomic, NULL, strerror(errno));

 	return fd;

 }

 RAZOR_EXPORT int

 razor_atomic_write(struct razor_atomic *atomic, int fd, const void *data,

 		   size_t size)

 {

 	int written;

 	if (atomic->error_str)

 		return -1;

 	while(size) {

 		written = write(fd, data, size);

 		if (written < 0) {

 			razor_atomic_set_error_str(atomic, NULL, strerror(errno));

 			(void)close(fd);

 			return -1;

 		}

 		data += written;

 		size -= written;

 	}

 	return 0;

 }

 RAZOR_EXPORT int

 razor_atomic_sync(struct razor_atomic *atomic, int handle)

 {

 	if (atomic->error_str)

 		return -1;

 	if (fsync(handle) < 0) {

 		razor_atomic_set_error_str(atomic, NULL, strerror(errno));

 		return -1;

 	}

 	free(atomic->error_path);

 	atomic->error_path = NULL;

 	return 0;

 }

 RAZOR_EXPORT int

 razor_atomic_close(struct razor_atomic *atomic, int fd)

 {

 	if (atomic->error_str)

 		return -1;

 	if (close(fd) < 0) {

 		razor_atomic_set_error_str(atomic, NULL, strerror(errno));

 		return -1;

 	}

 	free(atomic->error_path);

 	atomic->error_path = NULL;

 	return 0;

 }

 #endif		/* HAVE_WINDOWS_KVM */

 RAZOR_EXPORT const char *

 razor_atomic_get_error_msg(struct razor_atomic *atomic)

 {

 	if (!atomic->error_msg) {

 		if (atomic->error_path)

 			atomic->error_msg = razor_concat(atomic->error_path,

 							 ": ",

 							 atomic->error_str,

 							 NULL);

 		else

 			atomic->error_msg = strdup(atomic->error_str);

 	}

 	return atomic->error_msg;

 }

 RAZOR_EXPORT void

 razor_atomic_abort(struct razor_atomic *atomic, const char *error_msg)

 {

 	if (!atomic->error_str)

 		razor_atomic_set_error_str(atomic, NULL, error_msg);

 }

 RAZOR_EXPORT int

 razor_atomic_in_error_state(struct razor_atomic *atomic)

 {

 	return !!atomic->error_str;

 }