Source formatted

1 files changed, 25 insertions, 31 deletions

diff --git a/test/thread_id.c b/test/thread_id.c
index 0c804ed..ce60893 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)
 {