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
|
#ifndef FIO_OS_FREEBSD_H
#define FIO_OS_FREEBSD_H
#define FIO_OS os_freebsd
#include <errno.h>
#include <sys/sysctl.h>
#include <sys/disk.h>
#include <sys/thr.h>
#include <sys/socket.h>
#include <sys/param.h>
#include <sys/cpuset.h>
#include <sys/statvfs.h>
#include "../file.h"
#define FIO_HAVE_ODIRECT
#define FIO_USE_GENERIC_RAND
#define FIO_USE_GENERIC_INIT_RANDOM_STATE
#define FIO_HAVE_CHARDEV_SIZE
#define FIO_HAVE_FS_STAT
#define FIO_HAVE_TRIM
#define FIO_HAVE_GETTID
#define FIO_HAVE_CPU_AFFINITY
#define FIO_HAVE_SHM_ATTACH_REMOVED
#define OS_MAP_ANON MAP_ANON
#define fio_swap16(x) bswap16(x)
#define fio_swap32(x) bswap32(x)
#define fio_swap64(x) bswap64(x)
typedef off_t off64_t;
typedef cpuset_t os_cpu_mask_t;
#define fio_cpu_clear(mask, cpu) (void) CPU_CLR((cpu), (mask))
#define fio_cpu_set(mask, cpu) (void) CPU_SET((cpu), (mask))
#define fio_cpu_isset(mask, cpu) CPU_ISSET((cpu), (mask))
#define fio_cpu_count(mask) CPU_COUNT((mask))
static inline int fio_cpuset_init(os_cpu_mask_t *mask)
{
CPU_ZERO(mask);
return 0;
}
static inline int fio_cpuset_exit(os_cpu_mask_t *mask)
{
return 0;
}
static inline int fio_setaffinity(int pid, os_cpu_mask_t cpumask)
{
return cpuset_setaffinity(CPU_LEVEL_WHICH, CPU_WHICH_TID, pid, sizeof(cpumask), &cpumask);
}
static inline int fio_getaffinity(int pid, os_cpu_mask_t *cpumask)
{
return cpuset_getaffinity(CPU_LEVEL_WHICH, CPU_WHICH_PID, pid, sizeof(cpumask), cpumask);
}
#define FIO_MAX_CPUS CPU_SETSIZE
static inline int blockdev_size(struct fio_file *f, unsigned long long *bytes)
{
off_t size;
if (!ioctl(f->fd, DIOCGMEDIASIZE, &size)) {
*bytes = size;
return 0;
}
*bytes = 0;
return errno;
}
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)
{
int mib[2] = { CTL_HW, HW_PHYSMEM };
unsigned long long mem;
size_t len = sizeof(mem);
sysctl(mib, 2, &mem, &len, NULL, 0);
return mem;
}
static inline int gettid(void)
{
long lwpid;
thr_self(&lwpid);
return (int) lwpid;
}
static inline unsigned long long get_fs_free_size(const char *path)
{
unsigned long long ret;
struct statvfs s;
if (statvfs(path, &s) < 0)
return -1ULL;
ret = s.f_frsize;
ret *= (unsigned long long) s.f_bfree;
return ret;
}
static inline int os_trim(int fd, unsigned long long start,
unsigned long long len)
{
off_t range[2];
range[0] = start;
range[1] = len;
if (!ioctl(fd, DIOCGDELETE, range))
return 0;
return errno;
}
#ifdef MADV_FREE
#define FIO_MADV_FREE MADV_FREE
#endif
static inline int shm_attach_to_open_removed(void)
{
int x;
size_t len = sizeof(x);
if (sysctlbyname("kern.ipc.shm_allow_removed", &x, &len, NULL, 0) < 0)
return 0;
return x > 0 ? 1 : 0;
}
#endif
|
