X-Git-Url: https://git.kernel.dk/?p=fio.git;a=blobdiff_plain;f=os%2Fos-linux.h;h=aab74e581e5fc4cb76fa1eb00739ae1c145c9bb4;hp=dd783be3a61e63ee5955ffa121a5831c2413fe07;hb=ecc314ba7c5f02b7e90ac1dfbce1a74cd4e6d6fe;hpb=bdda7d79187a260c097de2ef3ffd90e022a3387b diff --git a/os/os-linux.h b/os/os-linux.h index dd783be3..aab74e58 100644 --- a/os/os-linux.h +++ b/os/os-linux.h @@ -4,12 +4,18 @@ #include #include #include +#include #include #include +#include +#include #include #include #include +#include "indirect.h" +#include "binject.h" + #define FIO_HAVE_LIBAIO #define FIO_HAVE_POSIXAIO #define FIO_HAVE_FADVISE @@ -23,18 +29,30 @@ #define FIO_HAVE_HUGETLB #define FIO_HAVE_RAWBIND #define FIO_HAVE_BLKTRACE +#define FIO_HAVE_STRSEP +#define FIO_HAVE_FALLOCATE +#define FIO_HAVE_POSIXAIO_FSYNC +#define FIO_HAVE_PSHARED_MUTEX +#define FIO_HAVE_CL_SIZE +#define FIO_HAVE_CGROUPS +#define FIO_HAVE_FDATASYNC +#define FIO_HAVE_FS_STAT +#define FIO_HAVE_TRIM +#define FIO_HAVE_BINJECT +#define FIO_HAVE_CLOCK_MONOTONIC + +#ifdef SYNC_FILE_RANGE_WAIT_BEFORE +#define FIO_HAVE_SYNC_FILE_RANGE +#endif -#define OS_MAP_ANON (MAP_ANONYMOUS) +#define OS_MAP_ANON MAP_ANONYMOUS #ifndef CLOCK_MONOTONIC #define CLOCK_MONOTONIC 1 #endif -#ifdef FIO_HAVE_CPU_AFFINITY typedef cpu_set_t os_cpu_mask_t; -#else -typedef int os_cpu_mask_t; -#endif + typedef struct drand48_data os_random_state_t; /* @@ -49,19 +67,33 @@ typedef struct drand48_data os_random_state_t; * If you are on an ancient glibc (2.3.2), then define GLIBC_2_3_2 if you want * the affinity helpers to work. */ -#ifdef FIO_HAVE_CPU_AFFINITY #ifndef GLIBC_2_3_2 -#define fio_setaffinity(td) \ - sched_setaffinity((td)->pid, sizeof((td)->o.cpumask), &(td)->o.cpumask) +#define fio_setaffinity(pid, cpumask) \ + sched_setaffinity((pid), sizeof(cpumask), &(cpumask)) #define fio_getaffinity(pid, ptr) \ sched_getaffinity((pid), sizeof(cpu_set_t), (ptr)) #else -#define fio_setaffinity(td) \ - sched_setaffinity((td)->pid, &(td)->o.cpumask) +#define fio_setaffinity(pid, cpumask) \ + sched_setaffinity((pid), &(cpumask)) #define fio_getaffinity(pid, ptr) \ sched_getaffinity((pid), (ptr)) #endif -#endif + +#define fio_cpu_clear(mask, cpu) CPU_CLR((cpu), (mask)) +#define fio_cpu_set(mask, cpu) CPU_SET((cpu), (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; +} + +#define FIO_MAX_CPUS CPU_SETSIZE static inline int ioprio_set(int which, int who, int ioprio) { @@ -98,10 +130,6 @@ static inline int vmsplice(int fd, const struct iovec *iov, } #endif -#ifndef SPLICE_F_UNMAP -#define SPLICE_F_UNMAP (0x10) -#endif - #define SPLICE_DEF_SIZE (64*1024) #ifdef FIO_HAVE_SYSLET @@ -115,7 +143,7 @@ struct async_head_user; static inline struct syslet_uatom * async_exec(struct syslet_uatom *atom, struct async_head_user *ahu) { - return (void *) syscall(__NR_async_exec, atom, ahu); + return (struct syslet_uatom *) syscall(__NR_async_exec, atom, ahu); } static inline long @@ -161,14 +189,18 @@ enum { #define BLKFLSBUF _IO(0x12,97) #endif -static inline int blockdev_invalidate_cache(int fd) +#ifndef BLKDISCARD +#define BLKDISCARD _IO(0x12,119) +#endif + +static inline int blockdev_invalidate_cache(struct fio_file *fd) { - return ioctl(fd, BLKFLSBUF); + return ioctl(f->fd, BLKFLSBUF); } -static inline int blockdev_size(int fd, unsigned long long *bytes) +static inline int blockdev_size(struct fio_file *f, unsigned long long *bytes) { - if (!ioctl(fd, BLKGETSIZE64, bytes)) + if (!ioctl(f->fd, BLKGETSIZE64, bytes)) return 0; return errno; @@ -229,4 +261,63 @@ static inline int fio_lookup_raw(dev_t dev, int *majdev, int *mindev) return 0; } +#ifdef O_NOATIME +#define FIO_O_NOATIME O_NOATIME +#else +#define FIO_O_NOATIME 0 +#endif + +#ifdef MADV_REMOVE +#define FIO_MADV_FREE MADV_REMOVE +#endif + +#define CACHE_LINE_FILE \ + "/sys/devices/system/cpu/cpu0/cache/index0/coherency_line_size" + +static inline int arch_cache_line_size(void) +{ + char size[32]; + int fd, ret; + + fd = open(CACHE_LINE_FILE, O_RDONLY); + if (fd < 0) + return -1; + + ret = read(fd, size, sizeof(size)); + + close(fd); + + if (ret <= 0) + return -1; + else + return atoi(size); +} + +static inline unsigned long long get_fs_size(const char *path) +{ + unsigned long long ret; + struct statfs s; + + if (statfs(path, &s) < 0) + return -1ULL; + + ret = s.f_bsize; + ret *= (unsigned long long) s.f_bfree; + return ret; +} + +static inline int os_trim(int fd, unsigned long long start, + unsigned long long len) +{ + uint64_t range[2]; + + range[0] = start; + range[1] = len; + + if (!ioctl(fd, BLKDISCARD, range)) + return 0; + + return errno; +} + #endif