Add FIO_PREFERRED_CLOCK_SOURCE to allow selection of clock source on a per-platform...
[fio.git] / os / os.h
CommitLineData
ebac4655
JA
1#ifndef FIO_OS_H
2#define FIO_OS_H
3
a14ca44a 4#include <sys/types.h>
203913ea 5#include <sys/socket.h>
03e20d68 6#include <pthread.h>
a14ca44a 7#include <unistd.h>
ecc314ba 8#include <stdlib.h>
a14ca44a 9
cca84643
JA
10enum {
11 os_linux = 1,
12 os_aix,
13 os_freebsd,
14 os_hpux,
15 os_mac,
16 os_netbsd,
17 os_solaris,
18 os_windows,
19
20 os_nr,
21};
22
ebac4655
JA
23#if defined(__linux__)
24#include "os-linux.h"
25#elif defined(__FreeBSD__)
26#include "os-freebsd.h"
7452440e
YT
27#elif defined(__NetBSD__)
28#include "os-netbsd.h"
2c0ecd28
JA
29#elif defined(__sun__)
30#include "os-solaris.h"
2afd826b
JA
31#elif defined(__APPLE__)
32#include "os-mac.h"
bf2e821a
CC
33#elif defined(_AIX)
34#include "os-aix.h"
c00a2289
JA
35#elif defined(__hpux)
36#include "os-hpux.h"
03e20d68
BC
37#elif defined(__CYGWIN__)
38#include "os-windows.h"
ebac4655
JA
39#else
40#error "unsupported os"
41#endif
42
43#ifdef FIO_HAVE_LIBAIO
44#include <libaio.h>
45#endif
46
47#ifdef FIO_HAVE_POSIXAIO
48#include <aio.h>
e97c1442
JA
49#ifndef FIO_OS_HAVE_AIOCB_TYPEDEF
50typedef struct aiocb os_aiocb_t;
51#endif
ebac4655
JA
52#endif
53
54#ifdef FIO_HAVE_SGIO
55#include <linux/fs.h>
56#include <scsi/sg.h>
57#endif
58
5921e80c 59#ifndef FIO_HAVE_STRSEP
00fb3c8d 60#include "../lib/strsep.h"
5921e80c
JA
61#endif
62
8e239cae
JA
63#ifdef MSG_DONTWAIT
64#define OS_MSG_DONTWAIT MSG_DONTWAIT
65#endif
66
ebac4655 67#ifndef FIO_HAVE_FADVISE
ecc314ba 68#define posix_fadvise(fd, off, len, advice) (0)
ebac4655 69
4d8947de 70#ifndef POSIX_FADV_DONTNEED
ebac4655
JA
71#define POSIX_FADV_DONTNEED (0)
72#define POSIX_FADV_SEQUENTIAL (0)
73#define POSIX_FADV_RANDOM (0)
4d8947de 74#endif
ebac4655
JA
75#endif /* FIO_HAVE_FADVISE */
76
77#ifndef FIO_HAVE_CPU_AFFINITY
e8462bd8 78#define fio_setaffinity(pid, mask) (0)
be4ecfdf
JA
79#define fio_getaffinity(pid, mask) do { } while (0)
80#define fio_cpu_clear(mask, cpu) do { } while (0)
85daf2c1 81#define fio_cpuset_exit(mask) (-1)
7452440e 82typedef unsigned long os_cpu_mask_t;
ebac4655
JA
83#endif
84
85#ifndef FIO_HAVE_IOPRIO
86#define ioprio_set(which, who, prio) (0)
87#endif
88
2c0ecd28 89#ifndef FIO_HAVE_ODIRECT
7d424763
JA
90#define OS_O_DIRECT 0
91#else
92#define OS_O_DIRECT O_DIRECT
2c0ecd28
JA
93#endif
94
74b025b0
JA
95#ifndef FIO_HAVE_HUGETLB
96#define SHM_HUGETLB 0
4d8947de 97#ifndef FIO_HUGE_PAGE
74b025b0 98#define FIO_HUGE_PAGE 0
4d8947de 99#endif
74b025b0 100#else
cb25df61 101#ifndef FIO_HUGE_PAGE
ee0e0a71 102#define FIO_HUGE_PAGE 4194304
74b025b0 103#endif
cb25df61 104#endif
74b025b0 105
5921e80c
JA
106#ifndef FIO_O_NOATIME
107#define FIO_O_NOATIME 0
108#endif
109
dc873b6f
JA
110#ifndef OS_RAND_MAX
111#define OS_RAND_MAX RAND_MAX
112#endif
113
ecc314ba
BC
114#ifdef FIO_HAVE_CLOCK_MONOTONIC
115#define FIO_TIMER_CLOCK CLOCK_MONOTONIC
116#else
117#define FIO_TIMER_CLOCK CLOCK_REALTIME
118#endif
119
07e5b264 120#ifndef FIO_HAVE_RAWBIND
8cc7afa9 121#define fio_lookup_raw(dev, majdev, mindev) 1
07e5b264
JA
122#endif
123
58483fa4
JA
124#ifndef FIO_PREFERRED_ENGINE
125#define FIO_PREFERRED_ENGINE "sync"
126#endif
127
b9fd788f
BC
128#ifndef FIO_OS_PATH_SEPARATOR
129#define FIO_OS_PATH_SEPARATOR "/"
130#endif
131
16de1bf9
BC
132#ifndef FIO_PREFERRED_CLOCK_SOURCE
133#define FIO_PREFERRED_CLOCK_SOURCE CS_CGETTIME
134#endif
135
fca70358
JA
136#ifndef FIO_MAX_JOBS
137#define FIO_MAX_JOBS 2048
138#endif
139
5ba13ea6
JA
140#ifndef FIO_OS_HAVE_SOCKLEN_T
141typedef socklen_t fio_socklen_t;
142#endif
143
901ebe18 144#ifdef FIO_USE_GENERIC_SWAP
9677bec3 145static inline uint16_t fio_swap16(uint16_t val)
232f9b73
JA
146{
147 return (val << 8) | (val >> 8);
148}
149
901ebe18 150static inline uint32_t fio_swap32(uint32_t val)
232f9b73
JA
151{
152 val = ((val & 0xff00ff00UL) >> 8) | ((val & 0x00ff00ffUL) << 8);
153
154 return (val >> 16) | (val << 16);
155}
156
901ebe18 157static inline uint64_t fio_swap64(uint64_t val)
232f9b73
JA
158{
159 val = ((val & 0xff00ff00ff00ff00ULL) >> 8) |
160 ((val & 0x00ff00ff00ff00ffULL) << 8);
161 val = ((val & 0xffff0000ffff0000ULL) >> 16) |
162 ((val & 0x0000ffff0000ffffULL) << 16);
163
164 return (val >> 32) | (val << 32);
165}
166#endif
167
8111092f
JA
168#ifdef FIO_LITTLE_ENDIAN
169#define __le16_to_cpu(x) (x)
170#define __le32_to_cpu(x) (x)
171#define __le64_to_cpu(x) (x)
172#define __cpu_to_le16(x) (x)
173#define __cpu_to_le32(x) (x)
174#define __cpu_to_le64(x) (x)
175#else
176#define __le16_to_cpu(x) fio_swap16(x)
177#define __le32_to_cpu(x) fio_swap32(x)
178#define __le64_to_cpu(x) fio_swap64(x)
179#define __cpu_to_le16(x) fio_swap16(x)
180#define __cpu_to_le32(x) fio_swap32(x)
181#define __cpu_to_le64(x) fio_swap64(x)
182#endif
183
184#define le16_to_cpu(val) ({ \
185 uint16_t *__val = &(val); \
186 __le16_to_cpu(*__val); \
187})
188#define le32_to_cpu(val) ({ \
189 uint32_t *__val = &(val); \
190 __le32_to_cpu(*__val); \
191})
192#define le64_to_cpu(val) ({ \
193 uint64_t *__val = &(val); \
194 __le64_to_cpu(*__val); \
195})
196#define cpu_to_le16(val) ({ \
197 uint16_t *__val = &(val); \
198 __cpu_to_le16(*__val); \
199})
200#define cpu_to_le32(val) ({ \
201 uint32_t *__val = &(val); \
202 __cpu_to_le32(*__val); \
203})
204#define cpu_to_le64(val) ({ \
205 uint64_t *__val = &(val); \
206 __cpu_to_le64(*__val); \
207})
208
5e62c22a
JA
209#ifndef FIO_HAVE_BLKTRACE
210static inline int is_blktrace(const char *fname)
211{
212 return 0;
213}
5921e80c 214struct thread_data;
5e62c22a
JA
215static inline int load_blktrace(struct thread_data *td, const char *fname)
216{
217 return 1;
218}
219#endif
220
eb7ccf38
JA
221#define FIO_DEF_CL_SIZE 128
222
223static inline int os_cache_line_size(void)
224{
225#ifdef FIO_HAVE_CL_SIZE
226 int ret = arch_cache_line_size();
227
228 if (ret <= 0)
229 return FIO_DEF_CL_SIZE;
230
231 return ret;
232#else
233 return FIO_DEF_CL_SIZE;
234#endif
235}
236
792d5517 237#ifdef FIO_USE_GENERIC_BDEV_SIZE
ecc314ba 238static inline int blockdev_size(struct fio_file *f, unsigned long long *bytes)
792d5517 239{
3b2e1464 240 off_t end;
792d5517 241
3b2e1464
JA
242 *bytes = 0;
243
ecc314ba 244 end = lseek(f->fd, 0, SEEK_END);
792d5517
JA
245 if (end < 0)
246 return errno;
247
248 *bytes = end;
249 return 0;
250}
251#endif
252
53531370
JA
253#ifdef FIO_USE_GENERIC_RAND
254typedef unsigned int os_random_state_t;
255
256static inline void os_random_seed(unsigned long seed, os_random_state_t *rs)
257{
258 srand(seed);
259}
260
261static inline long os_random_long(os_random_state_t *rs)
262{
263 long val;
264
265 val = rand_r(rs);
266 return val;
267}
268#endif
269
2e3bd4c2
JA
270#ifndef FIO_HAVE_FS_STAT
271static inline unsigned long long get_fs_size(const char *path)
272{
273 return 0;
274}
275#endif
276
c00a2289
JA
277#ifndef FIO_HAVE_CPU_ONLINE_SYSCONF
278static inline unsigned int cpus_online(void)
279{
280 return sysconf(_SC_NPROCESSORS_ONLN);
281}
282#endif
283
47f767c1
JA
284#ifndef FIO_HAVE_GETTID
285static inline int gettid(void)
286{
287 return getpid();
288}
289#endif
290
ebac4655 291#endif