summaryrefslogtreecommitdiffstats
path: root/test/thread_id.c
diff options
context:
space:
mode:
Diffstat (limited to 'test/thread_id.c')
-rw-r--r--test/thread_id.c56
1 files changed, 25 insertions, 31 deletions
diff --git a/test/thread_id.c b/test/thread_id.c
index 24aef80..edb3680 100644
--- a/test/thread_id.c
+++ b/test/thread_id.c
@@ -49,23 +49,21 @@ typedef struct _pthread_barrierattr {
} pthread_barrierattr_t;
typedef struct _pthread_barrier {
- uint32_t magic;
- unsigned int count;
- uint64_t nentered;
- pthread_cond_t cv;
+ uint32_t magic;
+ unsigned int count;
+ uint64_t nentered;
+ pthread_cond_t cv;
pthread_mutex_t mtx;
} pthread_barrier_t;
-int pthread_barrier_init(pthread_barrier_t *, const pthread_barrierattr_t *,
- unsigned int);
+int pthread_barrier_init(pthread_barrier_t *, const pthread_barrierattr_t *, unsigned int);
int pthread_barrier_wait(pthread_barrier_t *);
int pthread_barrier_destroy(pthread_barrier_t *);
static const uint32_t barrier_magic = 0xf00dd00f;
int
-pthread_barrier_init(pthread_barrier_t *barrier,
- const pthread_barrierattr_t *attr, unsigned int count)
+pthread_barrier_init(pthread_barrier_t *barrier, const pthread_barrierattr_t *attr, unsigned int count)
{
int rc;
@@ -98,8 +96,7 @@ barrier_lock(pthread_barrier_t *barrier)
int rc;
if ((rc = pthread_mutex_lock(&barrier->mtx)) != 0) {
- my_errx(EXIT_FAILURE, "%s: pthread_mutex_lock: %s", __func__,
- strerror(rc));
+ my_errx(EXIT_FAILURE, "%s: pthread_mutex_lock: %s", __func__, strerror(rc));
}
}
@@ -109,8 +106,7 @@ barrier_unlock(pthread_barrier_t *barrier)
int rc;
if ((rc = pthread_mutex_unlock(&barrier->mtx)) != 0) {
- my_errx(EXIT_FAILURE, "%s: pthread_mutex_unlock: %s", __func__,
- strerror(rc));
+ my_errx(EXIT_FAILURE, "%s: pthread_mutex_unlock: %s", __func__, strerror(rc));
}
}
@@ -125,7 +121,7 @@ pthread_barrier_destroy(pthread_barrier_t *barrier)
else if (barrier->nentered % barrier->count != 0)
rc = EBUSY;
else {
- rc = 0;
+ rc = 0;
barrier->magic = ~barrier->magic;
}
barrier_unlock(barrier);
@@ -142,7 +138,7 @@ pthread_barrier_destroy(pthread_barrier_t *barrier)
int
pthread_barrier_wait(pthread_barrier_t *barrier)
{
- int rc;
+ int rc;
uint64_t threshold;
if (barrier == NULL)
@@ -170,7 +166,7 @@ out:
return rc;
}
-#endif /* H5_HAVE_DARWIN */
+#endif /* H5_HAVE_DARWIN */
static void my_err(int, const char *, ...) H5_ATTR_FORMAT(printf, 2, 3);
@@ -178,7 +174,7 @@ static void
my_err(int code, const char *fmt, ...)
{
va_list ap;
- int errno_copy = errno;
+ int errno_copy = errno;
(void)HDfprintf(stderr, "thread_id: ");
HDva_start(ap, fmt);
@@ -188,22 +184,22 @@ my_err(int code, const char *fmt, ...)
HDexit(code);
}
-#define threads_failure(_call, _result) do { \
- my_errx(EXIT_FAILURE, "%s.%d: " #_call ": %s", __func__, \
- __LINE__, HDstrerror(_result)); \
-} while (false)
+#define threads_failure(_call, _result) \
+ do { \
+ my_errx(EXIT_FAILURE, "%s.%d: " #_call ": %s", __func__, __LINE__, HDstrerror(_result)); \
+ } while (false)
#define NTHREADS 5
-static volatile bool failed = false;
+static volatile bool failed = false;
static pthread_barrier_t barrier;
-static bool used[NTHREADS];
-static pthread_mutex_t used_lock;
+static bool used[NTHREADS];
+static pthread_mutex_t used_lock;
static void
atomic_printf(const char *fmt, ...)
{
- char buf[80];
+ char buf[80];
va_list ap;
ssize_t nprinted, nwritten;
@@ -218,8 +214,7 @@ atomic_printf(const char *fmt, ...)
nwritten = write(STDOUT_FILENO, buf, (size_t)nprinted);
if (nwritten < nprinted) {
- my_errx(EXIT_FAILURE, "%s.%d: write error or short write",
- __func__, __LINE__);
+ my_errx(EXIT_FAILURE, "%s.%d: write error or short write", __func__, __LINE__);
}
}
@@ -261,8 +256,7 @@ thread_main(void H5_ATTR_UNUSED *arg)
ntid = H5TS_thread_id();
if (ntid != tid) {
- atomic_printf("tid changed from %" PRIu64 " to %" PRIu64 " FAIL\n",
- tid, ntid);
+ atomic_printf("tid changed from %" PRIu64 " to %" PRIu64 " FAIL\n", tid, ntid);
failed = true;
}
return NULL;
@@ -275,7 +269,7 @@ pre_barrier_error:
int
main(void)
{
- int i, rc, times;
+ int i, rc, times;
pthread_t threads[NTHREADS];
/* Run H5open() to initialize the library's thread-ID freelist,
@@ -296,7 +290,7 @@ main(void)
for (times = 0; times < 2; times++) {
for (i = 0; i < NTHREADS; i++)
- used[i] = false; // access synchronized by thread create/join
+ used[i] = false; // access synchronized by thread create/join
for (i = 0; i < NTHREADS; i++) {
rc = pthread_create(&threads[i], NULL, thread_main, NULL);
@@ -320,7 +314,7 @@ main(void)
return failed ? EXIT_FAILURE : EXIT_SUCCESS;
}
-#else /*H5_HAVE_THREADSAFE && !H5_HAVE_WIN_THREADS*/
+#else /*H5_HAVE_THREADSAFE && !H5_HAVE_WIN_THREADS*/
int
main(void)
{