X-Git-Url: https://git.kernel.dk/?a=blobdiff_plain;f=os%2Fos-solaris.h;h=5b78cc2cc43cb384fb8d5e6e1f952bd6f618c1b6;hb=c3546b531f48a2ff413c9508aed465e0145c8dfc;hp=c0d3c30f82ba2e93b458d96bb1c5d9ef238eafd8;hpb=862745bf1f85ded2109a72e75a0070eb84900612;p=fio.git diff --git a/os/os-solaris.h b/os/os-solaris.h index c0d3c30f..5b78cc2c 100644 --- a/os/os-solaris.h +++ b/os/os-solaris.h @@ -1,29 +1,34 @@ #ifndef FIO_OS_SOLARIS_H #define FIO_OS_SOLARIS_H +#define FIO_OS os_solaris + #include #include +#include #include #include #include #include #include +#include #include "../file.h" -#define FIO_HAVE_POSIXAIO -#define FIO_HAVE_SOLARISAIO -#define FIO_HAVE_POSIXAIO_FSYNC #define FIO_HAVE_CPU_AFFINITY #define FIO_HAVE_PSHARED_MUTEX -#define FIO_HAVE_FDATASYNC #define FIO_HAVE_CHARDEV_SIZE #define FIO_USE_GENERIC_BDEV_SIZE +#define FIO_USE_GENERIC_INIT_RANDOM_STATE #define FIO_HAVE_GETTID #define OS_MAP_ANON MAP_ANON #define OS_RAND_MAX 2147483648UL +#define fio_swap16(x) BSWAP_16(x) +#define fio_swap32(x) BSWAP_32(x) +#define fio_swap64(x) BSWAP_64(x) + struct solaris_rand_seed { unsigned short r[3]; }; @@ -35,6 +40,9 @@ struct solaris_rand_seed { #define POSIX_MADV_RANDOM MADV_RANDOM #endif +#define os_ctime_r(x, y, z) ctime_r((x), (y), (z)) +#define FIO_OS_HAS_CTIME_R + typedef psetid_t os_cpu_mask_t; typedef struct solaris_rand_seed os_random_state_t; @@ -96,26 +104,54 @@ static inline int fio_set_odirect(int fd) #define fio_cpu_clear(mask, cpu) pset_assign(PS_NONE, (cpu), NULL) #define fio_cpu_set(mask, cpu) pset_assign(*(mask), (cpu), NULL) -static inline int fio_cpuset_init(os_cpu_mask_t *mask) +static inline int fio_cpu_isset(os_cpu_mask_t *mask, int cpu) { - int ret; + const unsigned int max_cpus = sysconf(_SC_NPROCESSORS_ONLN); + unsigned int num_cpus; + processorid_t *cpus; + int i, ret; - if (pset_create(mask) < 0) { - ret = errno; - return -1; + cpus = malloc(sizeof(*cpus) * max_cpus); + + if (pset_info(*mask, NULL, &num_cpus, cpus) < 0) { + free(cpus); + return 0; } + ret = 0; + for (i = 0; i < num_cpus; i++) { + if (cpus[i] == cpu) { + ret = 1; + break; + } + } + + free(cpus); + return ret; +} + +static inline int fio_cpu_count(os_cpu_mask_t *mask) +{ + unsigned int num_cpus; + + if (pset_info(*mask, NULL, &num_cpus, NULL) < 0) + return 0; + + return num_cpus; +} + +static inline int fio_cpuset_init(os_cpu_mask_t *mask) +{ + if (pset_create(mask) < 0) + return -1; + return 0; } static inline int fio_cpuset_exit(os_cpu_mask_t *mask) { - int ret; - - if (pset_destroy(*mask) < 0) { - ret = errno; + if (pset_destroy(*mask) < 0) return -1; - } return 0; }