Fix access-outside-array of o->rwmix[]
[fio.git] / os / os.h
... / ...
CommitLineData
1#ifndef FIO_OS_H
2#define FIO_OS_H
3
4#include <sys/types.h>
5#include <sys/socket.h>
6#include <fcntl.h>
7#include <pthread.h>
8#include <unistd.h>
9#include <stdlib.h>
10
11#include "../arch/arch.h"
12
13enum {
14 os_linux = 1,
15 os_aix,
16 os_freebsd,
17 os_hpux,
18 os_mac,
19 os_netbsd,
20 os_solaris,
21 os_windows,
22 os_android,
23
24 os_nr,
25};
26
27#if defined(__ANDROID__)
28#include "os-android.h"
29#elif defined(__linux__)
30#include "os-linux.h"
31#elif defined(__FreeBSD__)
32#include "os-freebsd.h"
33#elif defined(__NetBSD__)
34#include "os-netbsd.h"
35#elif defined(__sun__)
36#include "os-solaris.h"
37#elif defined(__APPLE__)
38#include "os-mac.h"
39#elif defined(_AIX)
40#include "os-aix.h"
41#elif defined(__hpux)
42#include "os-hpux.h"
43#elif defined(WIN32)
44#include "os-windows.h"
45#else
46#error "unsupported os"
47#endif
48
49#ifdef CONFIG_POSIXAIO
50#include <aio.h>
51#ifndef FIO_OS_HAVE_AIOCB_TYPEDEF
52typedef struct aiocb os_aiocb_t;
53#endif
54#endif
55
56#ifdef FIO_HAVE_SGIO
57#include <linux/fs.h>
58#include <scsi/sg.h>
59#endif
60
61#ifndef CONFIG_STRSEP
62#include "../lib/strsep.h"
63#endif
64
65#ifdef MSG_DONTWAIT
66#define OS_MSG_DONTWAIT MSG_DONTWAIT
67#endif
68
69#ifndef POSIX_FADV_DONTNEED
70#define POSIX_FADV_DONTNEED (0)
71#define POSIX_FADV_SEQUENTIAL (0)
72#define POSIX_FADV_RANDOM (0)
73#endif
74
75#ifndef FIO_HAVE_CPU_AFFINITY
76#define fio_setaffinity(pid, mask) (0)
77#define fio_getaffinity(pid, mask) do { } while (0)
78#define fio_cpu_clear(mask, cpu) do { } while (0)
79#define fio_cpuset_exit(mask) (-1)
80typedef unsigned long os_cpu_mask_t;
81#endif
82
83#ifndef FIO_HAVE_IOPRIO
84#define ioprio_set(which, who, prioclass, prio) (0)
85#endif
86
87#ifndef FIO_HAVE_ODIRECT
88#define OS_O_DIRECT 0
89#else
90#define OS_O_DIRECT O_DIRECT
91#endif
92
93#ifndef FIO_HAVE_HUGETLB
94#define SHM_HUGETLB 0
95#define MAP_HUGETLB 0
96#ifndef FIO_HUGE_PAGE
97#define FIO_HUGE_PAGE 0
98#endif
99#else
100#ifndef FIO_HUGE_PAGE
101#define FIO_HUGE_PAGE 4194304
102#endif
103#endif
104
105#ifndef FIO_HAVE_MMAP_HUGE
106#define MAP_HUGETLB 0
107#endif
108
109#ifndef FIO_O_NOATIME
110#define FIO_O_NOATIME 0
111#endif
112
113#ifndef OS_RAND_MAX
114#define OS_RAND_MAX RAND_MAX
115#endif
116
117#ifndef FIO_HAVE_RAWBIND
118#define fio_lookup_raw(dev, majdev, mindev) 1
119#endif
120
121#ifndef FIO_PREFERRED_ENGINE
122#define FIO_PREFERRED_ENGINE "sync"
123#endif
124
125#ifndef FIO_OS_PATH_SEPARATOR
126#define FIO_OS_PATH_SEPARATOR "/"
127#endif
128
129#ifndef FIO_PREFERRED_CLOCK_SOURCE
130#ifdef CONFIG_CLOCK_GETTIME
131#define FIO_PREFERRED_CLOCK_SOURCE CS_CGETTIME
132#else
133#define FIO_PREFERRED_CLOCK_SOURCE CS_GTOD
134#endif
135#endif
136
137#ifndef FIO_MAX_JOBS
138#define FIO_MAX_JOBS 2048
139#endif
140
141#ifndef CONFIG_SOCKLEN_T
142typedef unsigned int socklen_t;
143#endif
144
145#ifndef FIO_OS_HAS_CTIME_R
146#define os_ctime_r(x, y, z) (void) ctime_r((x), (y))
147#endif
148
149#ifdef FIO_USE_GENERIC_SWAP
150static inline uint16_t fio_swap16(uint16_t val)
151{
152 return (val << 8) | (val >> 8);
153}
154
155static inline uint32_t fio_swap32(uint32_t val)
156{
157 val = ((val & 0xff00ff00UL) >> 8) | ((val & 0x00ff00ffUL) << 8);
158
159 return (val >> 16) | (val << 16);
160}
161
162static inline uint64_t fio_swap64(uint64_t val)
163{
164 val = ((val & 0xff00ff00ff00ff00ULL) >> 8) |
165 ((val & 0x00ff00ff00ff00ffULL) << 8);
166 val = ((val & 0xffff0000ffff0000ULL) >> 16) |
167 ((val & 0x0000ffff0000ffffULL) << 16);
168
169 return (val >> 32) | (val << 32);
170}
171#endif
172
173#ifndef FIO_HAVE_BYTEORDER_FUNCS
174#ifdef CONFIG_LITTLE_ENDIAN
175#define __le16_to_cpu(x) (x)
176#define __le32_to_cpu(x) (x)
177#define __le64_to_cpu(x) (x)
178#define __cpu_to_le16(x) (x)
179#define __cpu_to_le32(x) (x)
180#define __cpu_to_le64(x) (x)
181#else
182#define __le16_to_cpu(x) fio_swap16(x)
183#define __le32_to_cpu(x) fio_swap32(x)
184#define __le64_to_cpu(x) fio_swap64(x)
185#define __cpu_to_le16(x) fio_swap16(x)
186#define __cpu_to_le32(x) fio_swap32(x)
187#define __cpu_to_le64(x) fio_swap64(x)
188#endif
189#endif /* FIO_HAVE_BYTEORDER_FUNCS */
190
191#define le16_to_cpu(val) ({ \
192 uint16_t *__val = &(val); \
193 __le16_to_cpu(*__val); \
194})
195#define le32_to_cpu(val) ({ \
196 uint32_t *__val = &(val); \
197 __le32_to_cpu(*__val); \
198})
199#define le64_to_cpu(val) ({ \
200 uint64_t *__val = &(val); \
201 __le64_to_cpu(*__val); \
202})
203#define cpu_to_le16(val) ({ \
204 uint16_t *__val = &(val); \
205 __cpu_to_le16(*__val); \
206})
207#define cpu_to_le32(val) ({ \
208 uint32_t *__val = &(val); \
209 __cpu_to_le32(*__val); \
210})
211#define cpu_to_le64(val) ({ \
212 uint64_t *__val = &(val); \
213 __cpu_to_le64(*__val); \
214})
215
216#ifndef FIO_HAVE_BLKTRACE
217static inline int is_blktrace(const char *fname)
218{
219 return 0;
220}
221struct thread_data;
222static inline int load_blktrace(struct thread_data *td, const char *fname)
223{
224 return 1;
225}
226#endif
227
228#define FIO_DEF_CL_SIZE 128
229
230static inline int os_cache_line_size(void)
231{
232#ifdef FIO_HAVE_CL_SIZE
233 int ret = arch_cache_line_size();
234
235 if (ret <= 0)
236 return FIO_DEF_CL_SIZE;
237
238 return ret;
239#else
240 return FIO_DEF_CL_SIZE;
241#endif
242}
243
244#ifdef FIO_USE_GENERIC_BDEV_SIZE
245static inline int blockdev_size(struct fio_file *f, unsigned long long *bytes)
246{
247 off_t end;
248
249 *bytes = 0;
250
251 end = lseek(f->fd, 0, SEEK_END);
252 if (end < 0)
253 return errno;
254
255 *bytes = end;
256 return 0;
257}
258#endif
259
260#ifdef FIO_USE_GENERIC_RAND
261typedef unsigned int os_random_state_t;
262
263static inline void os_random_seed(unsigned long seed, os_random_state_t *rs)
264{
265 srand(seed);
266}
267
268static inline long os_random_long(os_random_state_t *rs)
269{
270 long val;
271
272 val = rand_r(rs);
273 return val;
274}
275#endif
276
277#ifdef FIO_USE_GENERIC_INIT_RANDOM_STATE
278extern void td_fill_rand_seeds(struct thread_data *td);
279/*
280 * Initialize the various random states we need (random io, block size ranges,
281 * read/write mix, etc).
282 */
283static inline int init_random_state(struct thread_data *td, unsigned long *rand_seeds, int size)
284{
285 int fd;
286
287 fd = open("/dev/urandom", O_RDONLY);
288 if (fd == -1) {
289 return 1;
290 }
291
292 if (read(fd, rand_seeds, size) < size) {
293 close(fd);
294 return 1;
295 }
296
297 close(fd);
298 td_fill_rand_seeds(td);
299 return 0;
300}
301#endif
302
303#ifndef FIO_HAVE_FS_STAT
304static inline unsigned long long get_fs_size(const char *path)
305{
306 return 0;
307}
308#endif
309
310#ifndef FIO_HAVE_CPU_ONLINE_SYSCONF
311static inline unsigned int cpus_online(void)
312{
313 return sysconf(_SC_NPROCESSORS_ONLN);
314}
315#endif
316
317#ifndef FIO_HAVE_GETTID
318static inline int gettid(void)
319{
320 return getpid();
321}
322#endif
323
324#endif