Something went wrong. Try again.
A breadth-first version of the UNIX find command tavianator.com/projects/bfs.html
Something went wrong. Try again.
12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394// Copyright © Tavian Barnes <tavianator@tavianator.com>// SPDX-License-Identifier: 0BSD
#include "thread.h"
#include "bfstd.h"#include "diag.h"
#include <errno.h>#include <pthread.h>
#if __has_include(<pthread_np.h>)# include <pthread_np.h>#endif
#define THREAD_FALLIBLE(expr) \ do { \ int err = expr; \ if (err == 0) { \ return 0; \ } else { \ errno = err; \ return -1; \ } \ } while (0)
#define THREAD_INFALLIBLE(expr, ...) \ THREAD_INFALLIBLE_(expr, BFS_VA_IF(__VA_ARGS__)(__VA_ARGS__)(0))
#define THREAD_INFALLIBLE_(expr, allowed) \ int err = expr; \ bfs_verify(err == 0 || err == allowed, "%s: %s", #expr, xstrerror(err))
int thread_create(pthread_t *thread, const pthread_attr_t *attr, thread_fn *fn, void *arg) { THREAD_FALLIBLE(pthread_create(thread, attr, fn, arg));}
void thread_setname(pthread_t thread, const char *name) {#if BFS_HAS_PTHREAD_SETNAME_NP pthread_setname_np(thread, name);#elif BFS_HAS_PTHREAD_SET_NAME_NP pthread_set_name_np(thread, name);#endif}
void thread_join(pthread_t thread, void **ret) { THREAD_INFALLIBLE(pthread_join(thread, ret));}
int mutex_init(pthread_mutex_t *mutex, pthread_mutexattr_t *attr) { THREAD_FALLIBLE(pthread_mutex_init(mutex, attr));}
void mutex_lock(pthread_mutex_t *mutex) { THREAD_INFALLIBLE(pthread_mutex_lock(mutex));}
bool mutex_trylock(pthread_mutex_t *mutex) { THREAD_INFALLIBLE(pthread_mutex_trylock(mutex), EBUSY); return err == 0;}
void mutex_unlock(pthread_mutex_t *mutex) { THREAD_INFALLIBLE(pthread_mutex_unlock(mutex));}
void mutex_destroy(pthread_mutex_t *mutex) { THREAD_INFALLIBLE(pthread_mutex_destroy(mutex));}
int cond_init(pthread_cond_t *cond, pthread_condattr_t *attr) { THREAD_FALLIBLE(pthread_cond_init(cond, attr));}
void cond_wait(pthread_cond_t *cond, pthread_mutex_t *mutex) { THREAD_INFALLIBLE(pthread_cond_wait(cond, mutex));}
void cond_signal(pthread_cond_t *cond) { THREAD_INFALLIBLE(pthread_cond_signal(cond));}
void cond_broadcast(pthread_cond_t *cond) { THREAD_INFALLIBLE(pthread_cond_broadcast(cond));}
void cond_destroy(pthread_cond_t *cond) { THREAD_INFALLIBLE(pthread_cond_destroy(cond));}
void invoke_once(pthread_once_t *once, once_fn *fn) { THREAD_INFALLIBLE(pthread_once(once, fn));}