1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
|
#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"
/* MinGW won't declare rand_r unless _POSIX is defined */
#if defined(WIN32) && !defined(rand_r)
int rand_r(unsigned *);
#endif
#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
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) {
log_err("CreateDirectoryA = %d\n", GetLastError());
errno = win_to_posix_error(GetLastError());
return -1;
}
return 0;
}
#ifdef CONFIG_WINDOWS_XP
#include "os-windows-xp.h"
#else
#include "os-windows-7.h"
#endif
#endif /* FIO_OS_WINDOWS_H */
|
