[fio.git] / os / os-windows.h

#ifndef FIO_OS_WINDOWS_H
#define FIO_OS_WINDOWS_H

#define FIO_OS	os_windows

#include <sys/types.h>
#include <sys/shm.h>
#include <sys/stat.h>
#include <errno.h>
#include <winsock2.h>
#include <windows.h>
#include <psapi.h>
#include <stdlib.h>

#include "../smalloc.h"
#include "../debug.h"
#include "../file.h"
#include "../log.h"
#include "../lib/hweight.h"
#include "../oslib/strcasestr.h"
#include "../lib/types.h"

#include "windows/posix.h"
#include "os-windows-7.h"

#ifndef PTHREAD_STACK_MIN
#define PTHREAD_STACK_MIN 65535
#endif

#define FIO_HAVE_ODIRECT
#define FIO_HAVE_CPU_AFFINITY
#define FIO_HAVE_CHARDEV_SIZE
#define FIO_HAVE_GETTID
#define FIO_EMULATED_MKDIR_TWO

#define FIO_PREFERRED_ENGINE		"windowsaio"
#define FIO_PREFERRED_CLOCK_SOURCE	CS_CGETTIME
#define FIO_OS_PATH_SEPARATOR		'\\'

#define OS_MAP_ANON		MAP_ANON

#define fio_swap16(x)	_byteswap_ushort(x)
#define fio_swap32(x)	_byteswap_ulong(x)
#define fio_swap64(x)	_byteswap_uint64(x)

#define _SC_PAGESIZE			0x1
#define _SC_NPROCESSORS_ONLN	0x2
#define _SC_PHYS_PAGES			0x4

#define SA_RESTART	0
#define SIGPIPE		0

/*
 * Windows doesn't have O_DIRECT or O_SYNC, so define them
 * here so we can reject them at runtime when using the _open
 * interface (windowsaio uses CreateFile)
 */
#define O_DIRECT	0x1000000
#define O_SYNC		0x2000000

/* Windows doesn't support madvise, so any values will work */
#define POSIX_MADV_DONTNEED		0
#define POSIX_MADV_SEQUENTIAL	0
#define POSIX_MADV_RANDOM		0

#define F_SETFL			0x1
#define F_GETFL			0x2
#define O_NONBLOCK		FIONBIO

/* Winsock doesn't support MSG_WAIT */
#define OS_MSG_DONTWAIT	0

#ifndef S_ISSOCK
#define S_ISSOCK(x) 0
#endif

#define SIGCONT	0
#define SIGUSR1	1
#define SIGUSR2 2
#define SIGKILL 15 /* SIGKILL doesn't exists, let's use SIGTERM */

typedef int sigset_t;
typedef int siginfo_t;

struct sigaction
{
	void (*sa_handler)(int);
	sigset_t sa_mask;
	int sa_flags;
	void* (*sa_sigaction)(int, siginfo_t *, void*);
};

long sysconf(int name);

int kill(pid_t pid, int sig);
pid_t setsid(void);
int setgid(gid_t gid);
int setuid(uid_t uid);
int nice(int incr);
int sigaction(int sig, const struct sigaction *act,
		struct sigaction *oact);
int fsync(int fildes);
int fork(void);
int fcntl(int fildes, int cmd, ...);
int fdatasync(int fildes);
int lstat(const char * path, struct stat * buf);
uid_t geteuid(void);
char* ctime_r(const time_t *t, char *buf);
int nanosleep(const struct timespec *rqtp, struct timespec *rmtp);
ssize_t pread(int fildes, void *buf, size_t nbyte, off_t offset);
ssize_t pwrite(int fildes, const void *buf, size_t nbyte,
		off_t offset);

static inline int blockdev_size(struct fio_file *f, unsigned long long *bytes)
{
	int rc = 0;
	HANDLE hFile;
	GET_LENGTH_INFORMATION info;
	DWORD outBytes;

	if (f->hFile == NULL) {
		hFile = CreateFile(f->file_name, GENERIC_READ, FILE_SHARE_READ | FILE_SHARE_WRITE,
				NULL, OPEN_EXISTING, 0, NULL);
	} else {
		hFile = f->hFile;
	}

	if (DeviceIoControl(hFile, IOCTL_DISK_GET_LENGTH_INFO, NULL, 0, &info, sizeof(info), &outBytes, NULL))
		*bytes = info.Length.QuadPart;
	else
		rc = EIO;

	/* If we were passed a POSIX fd,
	 * close the HANDLE we created via CreateFile */
	if (hFile != INVALID_HANDLE_VALUE && f->hFile == NULL)
		CloseHandle(hFile);

	return rc;
}

static inline int chardev_size(struct fio_file *f, unsigned long long *bytes)
{
	return blockdev_size(f, bytes);
}

static inline int blockdev_invalidate_cache(struct fio_file *f)
{
	return ENOTSUP;
}

static inline unsigned long long os_phys_mem(void)
{
	long pagesize, pages;

	pagesize = sysconf(_SC_PAGESIZE);
	pages = sysconf(_SC_PHYS_PAGES);
	if (pages == -1 || pagesize == -1)
		return 0;

	return (unsigned long long) pages * (unsigned long long) pagesize;
}

#ifndef CONFIG_HAVE_GETTID
static inline int gettid(void)
{
	return GetCurrentThreadId();
}
#endif

static inline int init_random_seeds(uint64_t *rand_seeds, int size)
{
	HCRYPTPROV hCryptProv;

	if (!CryptAcquireContext(&hCryptProv, NULL, NULL, PROV_RSA_FULL, CRYPT_VERIFYCONTEXT))
	{
		errno = GetLastError();
		log_err("CryptAcquireContext() failed: error %d\n", errno);
		return 1;
	}

	if (!CryptGenRandom(hCryptProv, size, (BYTE*)rand_seeds)) {
		errno = GetLastError();
		log_err("CryptGenRandom() failed, error %d\n", errno);
		CryptReleaseContext(hCryptProv, 0);
		return 1;
	}

	CryptReleaseContext(hCryptProv, 0);
	return 0;
}

static inline int fio_set_sched_idle(void)
{
	/* SetThreadPriority returns nonzero for success */
	return (SetThreadPriority(GetCurrentThread(), THREAD_PRIORITY_IDLE))? 0 : -1;
}

static inline int fio_mkdir(const char *path, mode_t mode) {
	DWORD dwAttr = GetFileAttributesA(path);

	if (dwAttr != INVALID_FILE_ATTRIBUTES &&
	    (dwAttr & FILE_ATTRIBUTE_DIRECTORY)) {
		errno = EEXIST;
		return -1;
	}

	if (CreateDirectoryA(path, NULL) == 0) {
		/* Ignore errors if path is a device namespace */
		if (strcmp(path, "\\\\.") == 0) {
			errno = EEXIST;
			return -1;
		}
		errno = win_to_posix_error(GetLastError());
		return -1;
	}

	return 0;
}

#define FIO_HAVE_CPU_ONLINE_SYSCONF
unsigned int cpus_online(void);

int first_set_cpu(os_cpu_mask_t *cpumask);
int fio_setaffinity(int pid, os_cpu_mask_t cpumask);
int fio_cpuset_init(os_cpu_mask_t *mask);
int fio_getaffinity(int pid, os_cpu_mask_t *mask);
void fio_cpu_clear(os_cpu_mask_t *mask, int cpu);
void fio_cpu_set(os_cpu_mask_t *mask, int cpu);
int fio_cpu_isset(os_cpu_mask_t *mask, int cpu);
int fio_cpu_count(os_cpu_mask_t *mask);
int fio_cpuset_exit(os_cpu_mask_t *mask);

#endif /* FIO_OS_WINDOWS_H */
Commit	Line	Data
93bcfd20 BC	1	#ifndef FIO_OS_WINDOWS_H
	2	#define FIO_OS_WINDOWS_H
	3
	4	#define FIO_OS os_windows
	5
	6	#include <sys/types.h>
	7	#include <sys/shm.h>
	8	#include <sys/stat.h>
	9	#include <errno.h>
5aa23eb8	10	#include <winsock2.h>
93bcfd20 BC	11	#include <windows.h>
	12	#include <psapi.h>
	13	#include <stdlib.h>
	14
	15	#include "../smalloc.h"
a6ab5391	16	#include "../debug.h"
93bcfd20 BC	17	#include "../file.h"
93bcfd20 BC	18	#include "../log.h"
95db3079	19	#include "../lib/hweight.h"
984f30c9	20	#include "../oslib/strcasestr.h"
52fd65f4	21	#include "../lib/types.h"
93bcfd20	22
1f81991e	23	#include "windows/posix.h"
26dcc084	24	#include "os-windows-7.h"
1f81991e	25
f16b7405 BC	26	#ifndef PTHREAD_STACK_MIN
	27	#define PTHREAD_STACK_MIN 65535
	28	#endif
	29
93bcfd20 BC	30	#define FIO_HAVE_ODIRECT
	31	#define FIO_HAVE_CPU_AFFINITY
	32	#define FIO_HAVE_CHARDEV_SIZE
93bcfd20	33	#define FIO_HAVE_GETTID
df18600f	34	#define FIO_EMULATED_MKDIR_TWO
93bcfd20 BC	35
	36	#define FIO_PREFERRED_ENGINE "windowsaio"
	37	#define FIO_PREFERRED_CLOCK_SOURCE CS_CGETTIME
87262d97	38	#define FIO_OS_PATH_SEPARATOR '\\'
93bcfd20	39
93bcfd20 BC	40	#define OS_MAP_ANON MAP_ANON
93bcfd20 BC	41
93bcfd20 BC	42	#define fio_swap16(x) _byteswap_ushort(x)
	43	#define fio_swap32(x) _byteswap_ulong(x)
	44	#define fio_swap64(x) _byteswap_uint64(x)
	45
93bcfd20 BC	46	#define _SC_PAGESIZE 0x1
	47	#define _SC_NPROCESSORS_ONLN 0x2
	48	#define _SC_PHYS_PAGES 0x4
	49
	50	#define SA_RESTART 0
	51	#define SIGPIPE 0
	52
	53	/*
	54	* Windows doesn't have O_DIRECT or O_SYNC, so define them
	55	* here so we can reject them at runtime when using the _open
	56	* interface (windowsaio uses CreateFile)
	57	*/
	58	#define O_DIRECT 0x1000000
	59	#define O_SYNC 0x2000000
	60
	61	/* Windows doesn't support madvise, so any values will work */
	62	#define POSIX_MADV_DONTNEED 0
	63	#define POSIX_MADV_SEQUENTIAL 0
	64	#define POSIX_MADV_RANDOM 0
	65
	66	#define F_SETFL 0x1
	67	#define F_GETFL 0x2
	68	#define O_NONBLOCK FIONBIO
	69
	70	/* Winsock doesn't support MSG_WAIT */
	71	#define OS_MSG_DONTWAIT 0
	72
f64fe5ac AK	73	#ifndef S_ISSOCK
	74	#define S_ISSOCK(x) 0
	75	#endif
	76
93bcfd20	77	#define SIGCONT 0
84306c1d	78	#define SIGUSR1 1
2277d5d5	79	#define SIGUSR2 2
b50590bc	80	#define SIGKILL 15 /* SIGKILL doesn't exists, let's use SIGTERM */
93bcfd20 BC	81
	82	typedef int sigset_t;
	83	typedef int siginfo_t;
	84
	85	struct sigaction
	86	{
	87	void (*sa_handler)(int);
	88	sigset_t sa_mask;
	89	int sa_flags;
	90	void* (sa_sigaction)(int, siginfo_t , void*);
	91	};
	92
93bcfd20 BC	93	long sysconf(int name);
	94
	95	int kill(pid_t pid, int sig);
	96	pid_t setsid(void);
	97	int setgid(gid_t gid);
	98	int setuid(uid_t uid);
	99	int nice(int incr);
	100	int sigaction(int sig, const struct sigaction *act,
	101	struct sigaction *oact);
	102	int fsync(int fildes);
	103	int fork(void);
	104	int fcntl(int fildes, int cmd, ...);
	105	int fdatasync(int fildes);
	106	int lstat(const char * path, struct stat * buf);
	107	uid_t geteuid(void);
824d6ff4	108	char* ctime_r(const time_t t, char buf);
93bcfd20 BC	109	int nanosleep(const struct timespec rqtp, struct timespec rmtp);
	110	ssize_t pread(int fildes, void *buf, size_t nbyte, off_t offset);
	111	ssize_t pwrite(int fildes, const void *buf, size_t nbyte,
	112	off_t offset);
93bcfd20 BC	113
	114	static inline int blockdev_size(struct fio_file f, unsigned long long bytes)
	115	{
	116	int rc = 0;
	117	HANDLE hFile;
5aa23eb8 BC	118	GET_LENGTH_INFORMATION info;
5aa23eb8 BC	119	DWORD outBytes;
93bcfd20 BC	120
	121	if (f->hFile == NULL) {
	122	hFile = CreateFile(f->file_name, GENERIC_READ, FILE_SHARE_READ \| FILE_SHARE_WRITE,
	123	NULL, OPEN_EXISTING, 0, NULL);
	124	} else {
	125	hFile = f->hFile;
	126	}
	127
93bcfd20 BC	128	if (DeviceIoControl(hFile, IOCTL_DISK_GET_LENGTH_INFO, NULL, 0, &info, sizeof(info), &outBytes, NULL))
	129	*bytes = info.Length.QuadPart;
	130	else
	131	rc = EIO;
	132
	133	/* If we were passed a POSIX fd,
	134	* close the HANDLE we created via CreateFile */
	135	if (hFile != INVALID_HANDLE_VALUE && f->hFile == NULL)
	136	CloseHandle(hFile);
	137
	138	return rc;
	139	}
	140
	141	static inline int chardev_size(struct fio_file f, unsigned long long bytes)
	142	{
	143	return blockdev_size(f, bytes);
	144	}
	145
	146	static inline int blockdev_invalidate_cache(struct fio_file *f)
	147	{
22de5d77	148	return ENOTSUP;
93bcfd20 BC	149	}
	150
	151	static inline unsigned long long os_phys_mem(void)
	152	{
01d26955	153	long pagesize, pages;
93bcfd20	154
01d26955 BC	155	pagesize = sysconf(_SC_PAGESIZE);
	156	pages = sysconf(_SC_PHYS_PAGES);
	157	if (pages == -1 \|\| pagesize == -1)
	158	return 0;
	159
	160	return (unsigned long long) pages * (unsigned long long) pagesize;
93bcfd20 BC	161	}
93bcfd20 BC	162
de5ed0e4	163	#ifndef CONFIG_HAVE_GETTID
93bcfd20 BC	164	static inline int gettid(void)
	165	{
	166	return GetCurrentThreadId();
	167	}
de5ed0e4	168	#endif
93bcfd20	169
9781c080	170	static inline int init_random_seeds(uint64_t *rand_seeds, int size)
93bcfd20 BC	171	{
	172	HCRYPTPROV hCryptProv;
	173
	174	if (!CryptAcquireContext(&hCryptProv, NULL, NULL, PROV_RSA_FULL, CRYPT_VERIFYCONTEXT))
	175	{
	176	errno = GetLastError();
	177	log_err("CryptAcquireContext() failed: error %d\n", errno);
	178	return 1;
	179	}
	180
	181	if (!CryptGenRandom(hCryptProv, size, (BYTE*)rand_seeds)) {
	182	errno = GetLastError();
	183	log_err("CryptGenRandom() failed, error %d\n", errno);
	184	CryptReleaseContext(hCryptProv, 0);
	185	return 1;
	186	}
	187
	188	CryptReleaseContext(hCryptProv, 0);
93bcfd20 BC	189	return 0;
	190	}
	191
f2a2ce0e HL	192	static inline int fio_set_sched_idle(void)
	193	{
	194	/* SetThreadPriority returns nonzero for success */
	195	return (SetThreadPriority(GetCurrentThread(), THREAD_PRIORITY_IDLE))? 0 : -1;
	196	}
	197
df18600f SW	198	static inline int fio_mkdir(const char *path, mode_t mode) {
	199	DWORD dwAttr = GetFileAttributesA(path);
	200
	201	if (dwAttr != INVALID_FILE_ATTRIBUTES &&
	202	(dwAttr & FILE_ATTRIBUTE_DIRECTORY)) {
	203	errno = EEXIST;
	204	return -1;
	205	}
	206
	207	if (CreateDirectoryA(path, NULL) == 0) {
7273058c SW	208	/* Ignore errors if path is a device namespace */
	209	if (strcmp(path, "\\\\.") == 0) {
	210	errno = EEXIST;
	211	return -1;
	212	}
df18600f SW	213	errno = win_to_posix_error(GetLastError());
	214	return -1;
	215	}
	216
	217	return 0;
	218	}
	219
a1957954 BVA	220	#define FIO_HAVE_CPU_ONLINE_SYSCONF
a1957954 BVA	221	unsigned int cpus_online(void);
f2a2ce0e	222
a1957954 BVA	223	int first_set_cpu(os_cpu_mask_t *cpumask);
	224	int fio_setaffinity(int pid, os_cpu_mask_t cpumask);
	225	int fio_cpuset_init(os_cpu_mask_t *mask);
	226	int fio_getaffinity(int pid, os_cpu_mask_t *mask);
	227	void fio_cpu_clear(os_cpu_mask_t *mask, int cpu);
	228	void fio_cpu_set(os_cpu_mask_t *mask, int cpu);
	229	int fio_cpu_isset(os_cpu_mask_t *mask, int cpu);
	230	int fio_cpu_count(os_cpu_mask_t *mask);
	231	int fio_cpuset_exit(os_cpu_mask_t *mask);
	232
93bcfd20	233	#endif /* FIO_OS_WINDOWS_H */