X-Git-Url: https://git.kernel.dk/?p=fio.git;a=blobdiff_plain;f=os%2Fos-windows.h;h=9b045794f1de2884649dac818bd5b489354af846;hp=7bfe3d2255e4ea06dc191011c014f36b62435603;hb=c1e38868c299c2b3baa0f5a9f038bb1c79c09308;hpb=c2acfbac7e9eb8ac5407ac024c0fd000614c77e2 diff --git a/os/os-windows.h b/os/os-windows.h index 7bfe3d22..9b045794 100644 --- a/os/os-windows.h +++ b/os/os-windows.h @@ -15,9 +15,17 @@ #include "../smalloc.h" #include "../file.h" #include "../log.h" +#include "../lib/hweight.h" +#include "../oslib/strcasestr.h" +#include "../lib/types.h" #include "windows/posix.h" +/* Cygwin doesn't define rand_r if C99 or newer is being used */ +#if defined(WIN32) && !defined(rand_r) +int rand_r(unsigned *); +#endif + #ifndef PTHREAD_STACK_MIN #define PTHREAD_STACK_MIN 65535 #endif @@ -30,7 +38,7 @@ #define FIO_PREFERRED_ENGINE "windowsaio" #define FIO_PREFERRED_CLOCK_SOURCE CS_CGETTIME -#define FIO_OS_PATH_SEPARATOR "\\" +#define FIO_OS_PATH_SEPARATOR '\\' #define FIO_MAX_CPUS MAXIMUM_PROCESSORS @@ -104,11 +112,11 @@ int fcntl(int fildes, int cmd, ...); int fdatasync(int fildes); int lstat(const char * path, struct stat * buf); uid_t geteuid(void); +char* ctime_r(const time_t *t, char *buf); int nanosleep(const struct timespec *rqtp, struct timespec *rmtp); ssize_t pread(int fildes, void *buf, size_t nbyte, off_t offset); ssize_t pwrite(int fildes, const void *buf, size_t nbyte, off_t offset); -extern void td_fill_rand_seeds(struct thread_data *); static inline int blockdev_size(struct fio_file *f, unsigned long long *bytes) { @@ -144,9 +152,7 @@ static inline int chardev_size(struct fio_file *f, unsigned long long *bytes) static inline int blockdev_invalidate_cache(struct fio_file *f) { - /* There's no way to invalidate the cache in Windows - * so just pretend to succeed */ - return 0; + return ENOTSUP; } static inline unsigned long long os_phys_mem(void) @@ -161,11 +167,6 @@ static inline unsigned long long os_phys_mem(void) return (unsigned long long) pages * (unsigned long long) pagesize; } -static inline void os_get_tmpdir(char *path, int len) -{ - GetTempPath(len, path); -} - static inline int gettid(void) { return GetCurrentThreadId(); @@ -190,7 +191,7 @@ static inline int fio_setaffinity(int pid, os_cpu_mask_t cpumask) return (bSuccess)? 0 : -1; } -static inline void fio_getaffinity(int pid, os_cpu_mask_t *mask) +static inline int fio_getaffinity(int pid, os_cpu_mask_t *mask) { os_cpu_mask_t systemMask; @@ -201,20 +202,28 @@ static inline void fio_getaffinity(int pid, os_cpu_mask_t *mask) CloseHandle(h); } else { log_err("fio_getaffinity failed: failed to get handle for pid %d\n", pid); + return -1; } + + return 0; } static inline void fio_cpu_clear(os_cpu_mask_t *mask, int cpu) { - *mask ^= 1 << (cpu-1); + *mask &= ~(1ULL << cpu); } static inline void fio_cpu_set(os_cpu_mask_t *mask, int cpu) { - *mask |= 1 << cpu; + *mask |= 1ULL << cpu; +} + +static inline int fio_cpu_isset(os_cpu_mask_t *mask, int cpu) +{ + return (*mask & (1ULL << cpu)) != 0; } -static inline int fio_cpu_count(os_cpu_mask_t *mask, int cpu) +static inline int fio_cpu_count(os_cpu_mask_t *mask) { return hweight64(*mask); } @@ -230,7 +239,7 @@ static inline int fio_cpuset_exit(os_cpu_mask_t *mask) return 0; } -static inline int init_random_state(struct thread_data *td, unsigned long *rand_seeds, int size) +static inline int init_random_seeds(unsigned long *rand_seeds, int size) { HCRYPTPROV hCryptProv; @@ -249,7 +258,6 @@ static inline int init_random_state(struct thread_data *td, unsigned long *rand_ } CryptReleaseContext(hCryptProv, 0); - td_fill_rand_seeds(td); return 0; }