X-Git-Url: https://git.kernel.dk/?p=fio.git;a=blobdiff_plain;f=os%2Fos-solaris.h;h=6af25d2aee69f2306875fd0c59a2af29b3ff512d;hp=e1627d71f179ef3356d26e85000cf1f4e61eca8c;hb=2905de747b0aba7f3a5c24026f6fcaa17c88de83;hpb=e8d588e4d31f9d1e93b14499d23760d1d3d2db6b diff --git a/os/os-solaris.h b/os/os-solaris.h index e1627d71..6af25d2a 100644 --- a/os/os-solaris.h +++ b/os/os-solaris.h @@ -1,28 +1,33 @@ #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]; }; @@ -34,6 +39,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; @@ -52,7 +60,7 @@ static inline int chardev_size(struct fio_file *f, unsigned long long *bytes) static inline int blockdev_invalidate_cache(struct fio_file *f) { - return 0; + return ENOTSUP; } static inline unsigned long long os_phys_mem(void) @@ -77,9 +85,9 @@ static inline long os_random_long(os_random_state_t *rs) #define FIO_OS_DIRECTIO extern int directio(int, int); -static inline int fio_set_odirect(int fd) +static inline int fio_set_odirect(struct fio_file *f) { - if (directio(fd, DIRECTIO_ON) < 0) + if (directio(f->fd, DIRECTIO_ON) < 0) return errno; return 0; @@ -95,26 +103,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; }