diff options
Diffstat (limited to 'src/core/thread.c')
| -rw-r--r-- | src/core/thread.c | 17 |
1 files changed, 15 insertions, 2 deletions
diff --git a/src/core/thread.c b/src/core/thread.c index 4f714341..d1f46e3f 100644 --- a/src/core/thread.c +++ b/src/core/thread.c @@ -15,48 +15,56 @@ nni_mtx_init(nni_mtx *mtx) return (nni_plat_mtx_init(&mtx->mtx)); } + void nni_mtx_fini(nni_mtx *mtx) { nni_plat_mtx_fini(&mtx->mtx); } + void nni_mtx_lock(nni_mtx *mtx) { nni_plat_mtx_lock(&mtx->mtx); } + void nni_mtx_unlock(nni_mtx *mtx) { nni_plat_mtx_unlock(&mtx->mtx); } + int nni_mtx_trylock(nni_mtx *mtx) { return (nni_plat_mtx_trylock(&mtx->mtx)); } + int nni_cv_init(nni_cv *cv, nni_mtx *mtx) { return (nni_plat_cv_init(&cv->cv, &mtx->mtx)); } + void nni_cv_fini(nni_cv *cv) { nni_plat_cv_fini(&cv->cv); } + void nni_cv_wait(nni_cv *cv) { nni_plat_cv_wait(&cv->cv); } + int nni_cv_until(nni_cv *cv, nni_time until) { @@ -73,12 +81,14 @@ nni_cv_until(nni_cv *cv, nni_time until) return (nni_plat_cv_until(&cv->cv, until)); } + void nni_cv_wake(nni_cv *cv) { return (nni_plat_cv_wake(&cv->cv)); } + static void nni_thr_wrap(void *arg) { @@ -90,7 +100,7 @@ nni_thr_wrap(void *arg) nni_plat_cv_wait(&thr->cv); } nni_plat_mtx_unlock(&thr->mtx); - if (!stop) { + if ((!stop) && (thr->fn != NULL)) { thr->fn(thr->arg); } nni_plat_mtx_lock(&thr->mtx); @@ -99,6 +109,7 @@ nni_thr_wrap(void *arg) nni_plat_mtx_unlock(&thr->mtx); } + int nni_thr_init(nni_thr *thr, nni_thr_func fn, void *arg) { @@ -125,6 +136,7 @@ nni_thr_init(nni_thr *thr, nni_thr_func fn, void *arg) return (0); } + void nni_thr_run(nni_thr *thr) { @@ -134,6 +146,7 @@ nni_thr_run(nni_thr *thr) nni_plat_mtx_unlock(&thr->mtx); } + void nni_thr_fini(nni_thr *thr) { @@ -147,4 +160,4 @@ nni_thr_fini(nni_thr *thr) nni_plat_thr_fini(&thr->thr); nni_plat_cv_fini(&thr->cv); nni_plat_mtx_fini(&thr->mtx); -}
\ No newline at end of file +} |