X-Git-Url: https://git.kernel.dk/?a=blobdiff_plain;f=os%2Fos-solaris.h;h=2425ab9e0efd9b265e15bc24fa575fe78609ec26;hb=3b6879b271835dabefbe7bc626cb24ecb96547c1;hp=de948952f866541acf41cad840efc8fff0529769;hpb=6f7024e49e41fafcb838acbebf0c31fbcf35132f;p=fio.git diff --git a/os/os-solaris.h b/os/os-solaris.h index de948952..2425ab9e 100644 --- a/os/os-solaris.h +++ b/os/os-solaris.h @@ -1,42 +1,95 @@ #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 +#include +#include + +#include "../file.h" +#include "../lib/types.h" -#define FIO_HAVE_POSIXAIO -#define FIO_HAVE_SOLARISAIO -#define FIO_HAVE_FALLOCATE -#define FIO_HAVE_POSIXAIO_FSYNC #define FIO_HAVE_CPU_AFFINITY +#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 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]; }; +#ifndef POSIX_MADV_SEQUENTIAL +#define posix_madvise madvise +#define POSIX_MADV_SEQUENTIAL MADV_SEQUENTIAL +#define POSIX_MADV_DONTNEED MADV_DONTNEED +#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; -/* - * FIXME - */ -static inline int blockdev_size(int fd, unsigned long long *bytes) +static inline int chardev_size(struct fio_file *f, unsigned long long *bytes) { - return EINVAL; + struct dk_minfo info; + + *bytes = 0; + + if (ioctl(f->fd, DKIOCGMEDIAINFO, &info) < 0) + return errno; + + *bytes = info.dki_lbsize * info.dki_capacity; + return 0; } -static inline int blockdev_invalidate_cache(int fd) +static inline int blockdev_invalidate_cache(struct fio_file *f) { - return EINVAL; + return ENOTSUP; } static inline unsigned long long os_phys_mem(void) { - return 0; + long pagesize, pages; + + 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 unsigned long long get_fs_free_size(const char *path) +{ + 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; } static inline void os_random_seed(unsigned long seed, os_random_state_t *rs) @@ -56,9 +109,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; @@ -67,19 +120,78 @@ static inline int fio_set_odirect(int fd) /* * pset binding hooks for fio */ -#define fio_setaffinity(td) \ - pset_bind((td)->o.cpumask, P_PID, (td)->pid) -#define fio_getaffinity(pid, ptr) \ - sched_getaffinity((pid), sizeof(cpu_set_t), (ptr)) +#define fio_setaffinity(pid, cpumask) \ + 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) -#define fio_cpu_clear(mask, cpu) pset_assign(*(mask), (cpu), PS_NONE) -#define fio_cpu_set(mask, cpu) pset_assign(*(mask), (cpu), PS_MYID) -#define fio_cpuset_init(td) pset_create(&(td)->o.cpumask) -#define fio_cpuset_exit(td) pset_destroy((td)->o.cpumask) +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) + return -1; + + return 0; +} + +static inline int fio_cpuset_exit(os_cpu_mask_t *mask) +{ + if (pset_destroy(*mask) < 0) + return -1; + + return 0; +} + +static inline int gettid(void) +{ + return pthread_self(); +} /* * Should be enough, not aware of what (if any) restrictions Solaris has */ #define FIO_MAX_CPUS 16384 +#ifdef MADV_FREE +#define FIO_MADV_FREE MADV_FREE +#endif + #endif