X-Git-Url: https://git.kernel.dk/?p=fio.git;a=blobdiff_plain;f=os%2Fos-linux.h;h=01140e0d1ba0009942ec1913125324576c329de6;hp=c0f5327637bae11d572aacd315f5b018f2aa6ec3;hb=c36d16f5a0b9e3d505c9933bbbdccdb519ca4faf;hpb=2b52511f3f595e0932e7f9c55bed243e8fe0f4f8 diff --git a/os/os-linux.h b/os/os-linux.h index c0f53276..01140e0d 100644 --- a/os/os-linux.h +++ b/os/os-linux.h @@ -6,6 +6,8 @@ #include #include #include +#include +#include #include #include #include @@ -28,6 +30,10 @@ #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 OS_MAP_ANON MAP_ANONYMOUS @@ -35,11 +41,8 @@ #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; /* @@ -54,19 +57,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) { @@ -236,4 +253,30 @@ 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 + +#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); +} + #endif