X-Git-Url: https://git.kernel.dk/?a=blobdiff_plain;f=os%2Fos-solaris.h;h=5b78cc2cc43cb384fb8d5e6e1f952bd6f618c1b6;hb=de564c4d8d7f436d5b34656e72167142709c2a99;hp=ef37e499c26105e96ce16740c62198340384d7eb;hpb=232f9b73353e0322fe135d3029beecedaed7a17b;p=fio.git diff --git a/os/os-solaris.h b/os/os-solaris.h index ef37e499..5b78cc2c 100644 --- a/os/os-solaris.h +++ b/os/os-solaris.h @@ -1,8 +1,11 @@ #ifndef FIO_OS_SOLARIS_H #define FIO_OS_SOLARIS_H +#define FIO_OS os_solaris + #include #include +#include #include #include #include @@ -12,25 +15,16 @@ #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 -#if defined(_BIG_ENDIAN) -#define FIO_BIG_ENDIAN -#else -#define FIO_LITTLE_ENDIAN -#endif - #define fio_swap16(x) BSWAP_16(x) #define fio_swap32(x) BSWAP_32(x) #define fio_swap64(x) BSWAP_64(x) @@ -46,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; @@ -107,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; }