Fix memory leak in _fio_setup_rbd_data()
[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>
93bcfd20 6#include <fcntl.h>
03e20d68 7#include <pthread.h>
a14ca44a 8#include <unistd.h>
ecc314ba 9#include <stdlib.h>
a14ca44a 10
836fcc0f 11#include "../arch/arch.h"
e39c0676 12#include "../lib/types.h"
836fcc0f 13
cca84643
JA
14enum {
15 os_linux = 1,
16 os_aix,
17 os_freebsd,
18 os_hpux,
19 os_mac,
20 os_netbsd,
3cd4c66f 21 os_openbsd,
cca84643
JA
22 os_solaris,
23 os_windows,
ec5c6b12 24 os_android,
239b2882 25 os_dragonfly,
cca84643
JA
26
27 os_nr,
28};
29
ec5c6b12
AC
30#if defined(__ANDROID__)
31#include "os-android.h"
32#elif defined(__linux__)
ebac4655
JA
33#include "os-linux.h"
34#elif defined(__FreeBSD__)
35#include "os-freebsd.h"
3cd4c66f
J
36#elif defined(__OpenBSD__)
37#include "os-openbsd.h"
7452440e
YT
38#elif defined(__NetBSD__)
39#include "os-netbsd.h"
2c0ecd28
JA
40#elif defined(__sun__)
41#include "os-solaris.h"
2afd826b
JA
42#elif defined(__APPLE__)
43#include "os-mac.h"
bf2e821a
CC
44#elif defined(_AIX)
45#include "os-aix.h"
c00a2289
JA
46#elif defined(__hpux)
47#include "os-hpux.h"
93bcfd20 48#elif defined(WIN32)
03e20d68 49#include "os-windows.h"
239b2882
JA
50#elif defined (__DragonFly__)
51#include "os-dragonfly.h"
ebac4655
JA
52#else
53#error "unsupported os"
54#endif
55
67bf9823 56#ifdef CONFIG_POSIXAIO
ebac4655 57#include <aio.h>
e97c1442
JA
58#ifndef FIO_OS_HAVE_AIOCB_TYPEDEF
59typedef struct aiocb os_aiocb_t;
60#endif
ebac4655
JA
61#endif
62
63#ifdef FIO_HAVE_SGIO
64#include <linux/fs.h>
65#include <scsi/sg.h>
66#endif
67
4feafb1e 68#ifndef CONFIG_STRSEP
984f30c9 69#include "../oslib/strsep.h"
5921e80c
JA
70#endif
71
5ad7be56 72#ifndef CONFIG_STRLCAT
984f30c9 73#include "../oslib/strlcat.h"
5ad7be56
KD
74#endif
75
8e239cae
JA
76#ifdef MSG_DONTWAIT
77#define OS_MSG_DONTWAIT MSG_DONTWAIT
78#endif
79
4d8947de 80#ifndef POSIX_FADV_DONTNEED
ebac4655
JA
81#define POSIX_FADV_DONTNEED (0)
82#define POSIX_FADV_SEQUENTIAL (0)
83#define POSIX_FADV_RANDOM (0)
4d8947de 84#endif
ebac4655
JA
85
86#ifndef FIO_HAVE_CPU_AFFINITY
be4ecfdf
JA
87#define fio_getaffinity(pid, mask) do { } while (0)
88#define fio_cpu_clear(mask, cpu) do { } while (0)
7452440e 89typedef unsigned long os_cpu_mask_t;
3e55d40f
TK
90
91static inline int fio_setaffinity(int pid, os_cpu_mask_t cpumask)
92{
93 return 0;
94}
95
96static inline int fio_cpuset_exit(os_cpu_mask_t *mask)
97{
98 return -1;
99}
100
101static inline int fio_cpus_split(os_cpu_mask_t *mask, unsigned int cpu_index)
102{
103 return 0;
104}
c2acfbac
JA
105#else
106extern int fio_cpus_split(os_cpu_mask_t *mask, unsigned int cpu);
ebac4655
JA
107#endif
108
109#ifndef FIO_HAVE_IOPRIO
28727df7 110#define ioprio_set(which, who, prioclass, prio) (0)
ebac4655
JA
111#endif
112
2c0ecd28 113#ifndef FIO_HAVE_ODIRECT
7d424763
JA
114#define OS_O_DIRECT 0
115#else
116#define OS_O_DIRECT O_DIRECT
2c0ecd28
JA
117#endif
118
d01612f3
CM
119#ifdef OS_O_ATOMIC
120#define FIO_O_ATOMIC OS_O_ATOMIC
121#else
122#define FIO_O_ATOMIC 0
123#endif
124
74b025b0
JA
125#ifndef FIO_HAVE_HUGETLB
126#define SHM_HUGETLB 0
d6dc02fb 127#define MAP_HUGETLB 0
4d8947de 128#ifndef FIO_HUGE_PAGE
74b025b0 129#define FIO_HUGE_PAGE 0
4d8947de 130#endif
74b025b0 131#else
cb25df61 132#ifndef FIO_HUGE_PAGE
ee0e0a71 133#define FIO_HUGE_PAGE 4194304
74b025b0 134#endif
cb25df61 135#endif
74b025b0 136
39b93568
JA
137#ifndef FIO_HAVE_MMAP_HUGE
138#define MAP_HUGETLB 0
139#endif
140
5921e80c
JA
141#ifndef FIO_O_NOATIME
142#define FIO_O_NOATIME 0
143#endif
144
dc873b6f
JA
145#ifndef OS_RAND_MAX
146#define OS_RAND_MAX RAND_MAX
147#endif
148
07e5b264 149#ifndef FIO_HAVE_RAWBIND
8cc7afa9 150#define fio_lookup_raw(dev, majdev, mindev) 1
07e5b264
JA
151#endif
152
58483fa4 153#ifndef FIO_PREFERRED_ENGINE
df96a39e 154#define FIO_PREFERRED_ENGINE "psync"
58483fa4
JA
155#endif
156
b9fd788f
BC
157#ifndef FIO_OS_PATH_SEPARATOR
158#define FIO_OS_PATH_SEPARATOR "/"
159#endif
160
16de1bf9 161#ifndef FIO_PREFERRED_CLOCK_SOURCE
86e53416 162#ifdef CONFIG_CLOCK_GETTIME
16de1bf9 163#define FIO_PREFERRED_CLOCK_SOURCE CS_CGETTIME
86e53416
BC
164#else
165#define FIO_PREFERRED_CLOCK_SOURCE CS_GTOD
166#endif
16de1bf9
BC
167#endif
168
fca70358
JA
169#ifndef FIO_MAX_JOBS
170#define FIO_MAX_JOBS 2048
171#endif
172
67bf9823
JA
173#ifndef CONFIG_SOCKLEN_T
174typedef unsigned int socklen_t;
5ba13ea6
JA
175#endif
176
45054cbe 177#ifndef FIO_OS_HAS_CTIME_R
1f81991e 178#define os_ctime_r(x, y, z) (void) ctime_r((x), (y))
45054cbe
SD
179#endif
180
901ebe18 181#ifdef FIO_USE_GENERIC_SWAP
9677bec3 182static inline uint16_t fio_swap16(uint16_t val)
232f9b73
JA
183{
184 return (val << 8) | (val >> 8);
185}
186
901ebe18 187static inline uint32_t fio_swap32(uint32_t val)
232f9b73
JA
188{
189 val = ((val & 0xff00ff00UL) >> 8) | ((val & 0x00ff00ffUL) << 8);
190
191 return (val >> 16) | (val << 16);
192}
193
901ebe18 194static inline uint64_t fio_swap64(uint64_t val)
232f9b73
JA
195{
196 val = ((val & 0xff00ff00ff00ff00ULL) >> 8) |
197 ((val & 0x00ff00ff00ff00ffULL) << 8);
198 val = ((val & 0xffff0000ffff0000ULL) >> 16) |
199 ((val & 0x0000ffff0000ffffULL) << 16);
200
201 return (val >> 32) | (val << 32);
202}
203#endif
204
ec5c6b12 205#ifndef FIO_HAVE_BYTEORDER_FUNCS
0dcebdf4 206#ifdef CONFIG_LITTLE_ENDIAN
8111092f
JA
207#define __le16_to_cpu(x) (x)
208#define __le32_to_cpu(x) (x)
209#define __le64_to_cpu(x) (x)
210#define __cpu_to_le16(x) (x)
211#define __cpu_to_le32(x) (x)
212#define __cpu_to_le64(x) (x)
213#else
214#define __le16_to_cpu(x) fio_swap16(x)
215#define __le32_to_cpu(x) fio_swap32(x)
216#define __le64_to_cpu(x) fio_swap64(x)
217#define __cpu_to_le16(x) fio_swap16(x)
218#define __cpu_to_le32(x) fio_swap32(x)
219#define __cpu_to_le64(x) fio_swap64(x)
220#endif
ec5c6b12 221#endif /* FIO_HAVE_BYTEORDER_FUNCS */
8111092f 222
0bbe46e7 223#ifdef FIO_INTERNAL
8111092f 224#define le16_to_cpu(val) ({ \
ff8039b7 225 typecheck(uint16_t, val); \
c46fda90 226 __le16_to_cpu(val); \
8111092f
JA
227})
228#define le32_to_cpu(val) ({ \
ff8039b7 229 typecheck(uint32_t, val); \
c46fda90 230 __le32_to_cpu(val); \
8111092f
JA
231})
232#define le64_to_cpu(val) ({ \
ff8039b7
JA
233 typecheck(uint64_t, val); \
234 __le64_to_cpu(val); \
8111092f 235})
0bbe46e7
DG
236#endif
237
8111092f 238#define cpu_to_le16(val) ({ \
ff8039b7 239 typecheck(uint16_t, val); \
c46fda90 240 __cpu_to_le16(val); \
8111092f
JA
241})
242#define cpu_to_le32(val) ({ \
ff8039b7 243 typecheck(uint32_t, val); \
c46fda90 244 __cpu_to_le32(val); \
8111092f
JA
245})
246#define cpu_to_le64(val) ({ \
ff8039b7 247 typecheck(uint64_t, val); \
c46fda90 248 __cpu_to_le64(val); \
8111092f
JA
249})
250
5e62c22a 251#ifndef FIO_HAVE_BLKTRACE
d95b34a6 252static inline int is_blktrace(const char *fname, int *need_swap)
5e62c22a
JA
253{
254 return 0;
255}
5921e80c 256struct thread_data;
d95b34a6
JA
257static inline int load_blktrace(struct thread_data *td, const char *fname,
258 int need_swap)
5e62c22a
JA
259{
260 return 1;
261}
262#endif
263
eb7ccf38
JA
264#define FIO_DEF_CL_SIZE 128
265
266static inline int os_cache_line_size(void)
267{
268#ifdef FIO_HAVE_CL_SIZE
269 int ret = arch_cache_line_size();
270
271 if (ret <= 0)
272 return FIO_DEF_CL_SIZE;
273
274 return ret;
275#else
276 return FIO_DEF_CL_SIZE;
277#endif
278}
279
792d5517 280#ifdef FIO_USE_GENERIC_BDEV_SIZE
ecc314ba 281static inline int blockdev_size(struct fio_file *f, unsigned long long *bytes)
792d5517 282{
3b2e1464 283 off_t end;
792d5517 284
3b2e1464
JA
285 *bytes = 0;
286
ecc314ba 287 end = lseek(f->fd, 0, SEEK_END);
792d5517
JA
288 if (end < 0)
289 return errno;
290
291 *bytes = end;
292 return 0;
293}
294#endif
295
53531370
JA
296#ifdef FIO_USE_GENERIC_RAND
297typedef unsigned int os_random_state_t;
298
299static inline void os_random_seed(unsigned long seed, os_random_state_t *rs)
300{
301 srand(seed);
302}
303
304static inline long os_random_long(os_random_state_t *rs)
305{
306 long val;
307
308 val = rand_r(rs);
309 return val;
310}
311#endif
312
93bcfd20
BC
313#ifdef FIO_USE_GENERIC_INIT_RANDOM_STATE
314extern void td_fill_rand_seeds(struct thread_data *td);
315/*
316 * Initialize the various random states we need (random io, block size ranges,
317 * read/write mix, etc).
318 */
319static inline int init_random_state(struct thread_data *td, unsigned long *rand_seeds, int size)
320{
321 int fd;
322
323 fd = open("/dev/urandom", O_RDONLY);
324 if (fd == -1) {
325 return 1;
326 }
327
328 if (read(fd, rand_seeds, size) < size) {
329 close(fd);
330 return 1;
331 }
332
333 close(fd);
334 td_fill_rand_seeds(td);
335 return 0;
336}
337#endif
338
2e3bd4c2 339#ifndef FIO_HAVE_FS_STAT
c08ad04c 340static inline unsigned long long get_fs_free_size(const char *path)
2e3bd4c2
JA
341{
342 return 0;
343}
344#endif
345
c5dd5d97
DQZ
346#ifdef __powerpc64__
347#define FIO_HAVE_CPU_ONLINE_SYSCONF
348static inline unsigned int cpus_online(void)
349{
350 return sysconf(_SC_NPROCESSORS_CONF);
351}
352#endif
353
c00a2289
JA
354#ifndef FIO_HAVE_CPU_ONLINE_SYSCONF
355static inline unsigned int cpus_online(void)
356{
357 return sysconf(_SC_NPROCESSORS_ONLN);
358}
359#endif
360
7221da37 361#ifndef CPU_COUNT
6cf71c24
JA
362#ifdef FIO_HAVE_CPU_AFFINITY
363static inline int CPU_COUNT(os_cpu_mask_t *mask)
364{
365 int max_cpus = cpus_online();
366 int nr_cpus, i;
367
368 for (i = 0, nr_cpus = 0; i < max_cpus; i++)
369 if (fio_cpu_isset(mask, i))
370 nr_cpus++;
371
372 return nr_cpus;
373}
374#endif
375#endif
376
47f767c1
JA
377#ifndef FIO_HAVE_GETTID
378static inline int gettid(void)
379{
380 return getpid();
381}
382#endif
383
ebac4655 384#endif