diff --git a/include/affinity.h b/include/affinity.h index d0a9f35bb..89b5ff7da 100644 --- a/include/affinity.h +++ b/include/affinity.h @@ -7,6 +7,7 @@ #define _AFFINITY_H #include +#include #ifdef _POSIX #include diff --git a/include/shared.h b/include/shared.h index 3639c546b..e60a4b1b7 100644 --- a/include/shared.h +++ b/include/shared.h @@ -170,9 +170,6 @@ char *strstatus (const uint threads_status); void status (); -#ifdef _WIN -void fsync (int fd); -#endif void myabort (void); void myquit (void); diff --git a/src/affinity.c b/src/affinity.c index 0ab4b032a..26ab61488 100644 --- a/src/affinity.c +++ b/src/affinity.c @@ -3,6 +3,10 @@ * License.....: MIT */ +#ifdef __APPLE__ +#include +#endif + #include "common.h" #include "types_int.h" #include "memory.h" @@ -14,19 +18,20 @@ static int pthread_setaffinity_np (pthread_t thread, size_t cpu_size, cpu_set_t { int core; - for (core = 0; core < (8 * (int)cpu_size); core++) - if (CPU_ISSET(core, cpu_set)) break; + for (core = 0; core < (8 * (int) cpu_size); core++) + { + if (CPU_ISSET (core, cpu_set)) break; + } thread_affinity_policy_data_t policy = { core }; const int rc = thread_policy_set (pthread_mach_thread_np (thread), THREAD_AFFINITY_POLICY, (thread_policy_t) &policy, 1); - if (data.quiet == 0) + if (rc != KERN_SUCCESS) { - if (rc != KERN_SUCCESS) - { - log_error ("ERROR: %s : %d", "thread_policy_set()", rc); - } + log_error ("ERROR: %s : %d", "thread_policy_set()", rc); + + exit (-1); } return rc; diff --git a/src/shared.c b/src/shared.c index f4079b799..de868f112 100644 --- a/src/shared.c +++ b/src/shared.c @@ -41,7 +41,7 @@ extern hc_global_data_t data; #ifdef WIN -void fsync (int fd) +static void fsync (int fd) { HANDLE h = (HANDLE) _get_osfhandle (fd);