X-Git-Url: https://git.kernel.dk/?p=fio.git;a=blobdiff_plain;f=os%2Fos-linux.h;h=8d3b97ea1f04015af100c990aba4d50914f99df9;hp=1cd8272d5241750c67107536b2a0a1268236e7c0;hb=610a730c79c90298d41cb3138041e83ba9cdb1d2;hpb=0fe2187702d5d65e2b0f47e23824f41572eb4446 diff --git a/os/os-linux.h b/os/os-linux.h index 1cd8272d..8d3b97ea 100644 --- a/os/os-linux.h +++ b/os/os-linux.h @@ -4,14 +4,19 @@ #include #include #include +#include #include #include #include +#include #include #include #include +#include #include "indirect.h" +#include "binject.h" +#include "../file.h" #define FIO_HAVE_LIBAIO #define FIO_HAVE_POSIXAIO @@ -31,6 +36,25 @@ #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 +#define FIO_HAVE_GETTID + +/* + * Can only enable this for newer glibcs, or the header and defines are + * missing + */ +#if __GLIBC__ >= 2 && __GLIBC_MINOR__ >= 6 +#define FIO_HAVE_LINUX_FALLOCATE +#endif + +#ifdef SYNC_FILE_RANGE_WAIT_BEFORE +#define FIO_HAVE_SYNC_FILE_RANGE +#endif #define OS_MAP_ANON MAP_ANONYMOUS @@ -55,13 +79,13 @@ typedef struct drand48_data os_random_state_t; * the affinity helpers to work. */ #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 @@ -87,6 +111,11 @@ static inline int ioprio_set(int which, int who, int ioprio) return syscall(__NR_ioprio_set, which, who, ioprio); } +static inline int gettid(void) +{ + return syscall(__NR_gettid); +} + /* * Just check for SPLICE_F_MOVE, if that isn't there, assume the others * aren't either. @@ -176,14 +205,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 *f) { - 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; @@ -250,6 +283,18 @@ static inline int fio_lookup_raw(dev_t dev, int *majdev, int *mindev) #define FIO_O_NOATIME 0 #endif +#ifdef MADV_REMOVE +#define FIO_MADV_FREE MADV_REMOVE +#endif + +#if __BYTE_ORDER == __LITTLE_ENDIAN +#define FIO_LITTLE_ENDIAN +#elif __BYTE_ORDER == __BIG_ENDIAN +#define FIO_BIG_ENDIAN +#else +#error "Unknown endianness" +#endif + #define CACHE_LINE_FILE \ "/sys/devices/system/cpu/cpu0/cache/index0/coherency_line_size" @@ -263,10 +308,40 @@ static inline int arch_cache_line_size(void) return -1; ret = read(fd, size, sizeof(size)); + + close(fd); + if (ret <= 0) return -1; + else + return atoi(size); +} - 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