X-Git-Url: https://git.kernel.dk/?a=blobdiff_plain;f=os%2Fos-solaris.h;h=1a411af664e8de947fc0497f59a12648e8d60fe0;hb=2a09811cf987fce7f125178ba444aa31f1a57ab4;hp=5efd7ac1e96481ec4ed0645c2c2bb88a66cbdf6d;hpb=49758e11f3658686ccd1c61724a5eba142f3ee4f;p=fio.git diff --git a/os/os-solaris.h b/os/os-solaris.h index 5efd7ac1..1a411af6 100644 --- a/os/os-solaris.h +++ b/os/os-solaris.h @@ -5,36 +5,29 @@ #include #include +#include #include -#include +#include #include #include #include #include +#include +#include #include "../file.h" +#include "../lib/types.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_HAVE_FS_STAT #define FIO_USE_GENERIC_INIT_RANDOM_STATE #define FIO_HAVE_GETTID -#define FIO_HAVE_FADVISE #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) @@ -54,7 +47,6 @@ struct solaris_rand_seed { #define FIO_OS_HAS_CTIME_R typedef psetid_t os_cpu_mask_t; -typedef struct solaris_rand_seed os_random_state_t; static inline int chardev_size(struct fio_file *f, unsigned long long *bytes) { @@ -71,34 +63,39 @@ 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) { - return 0; -} + long pagesize, pages; -static inline void os_random_seed(unsigned long seed, os_random_state_t *rs) -{ - rs->r[0] = seed & 0xffff; - seed >>= 16; - rs->r[1] = seed & 0xffff; - seed >>= 16; - rs->r[2] = seed & 0xffff; - seed48(rs->r); + pagesize = sysconf(_SC_PAGESIZE); + pages = sysconf(_SC_PHYS_PAGES); + if (pages == -1 || pagesize == -1) + return 0; + + return (unsigned long long) pages * (unsigned long long) pagesize; } -static inline long os_random_long(os_random_state_t *rs) +static inline unsigned long long get_fs_free_size(const char *path) { - return nrand48(rs->r); + unsigned long long ret; + struct statvfs s; + + if (statvfs(path, &s) < 0) + return -1ULL; + + ret = s.f_frsize; + ret *= (unsigned long long) s.f_bfree; + return ret; } #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; @@ -108,12 +105,49 @@ static inline int fio_set_odirect(int fd) * pset binding hooks for fio */ #define fio_setaffinity(pid, cpumask) \ - pset_bind((cpumask), P_PID, (pid), NULL) + pset_bind((cpumask), P_LWPID, (pid), NULL) #define fio_getaffinity(pid, ptr) ({ 0; }) #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 bool fio_cpu_isset(os_cpu_mask_t *mask, int cpu) +{ + const unsigned int max_cpus = sysconf(_SC_NPROCESSORS_ONLN); + unsigned int num_cpus; + processorid_t *cpus; + bool ret; + int i; + + cpus = malloc(sizeof(*cpus) * max_cpus); + + if (pset_info(*mask, NULL, &num_cpus, cpus) < 0) { + free(cpus); + return false; + } + + ret = false; + for (i = 0; i < num_cpus; i++) { + if (cpus[i] == cpu) { + ret = true; + 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)