diff options
| author | Garrett D'Amore <garrett@damore.org> | 2021-12-05 17:28:40 -0500 |
|---|---|---|
| committer | Garrett D'Amore <garrett@damore.org> | 2021-12-05 17:28:40 -0500 |
| commit | eee06d1e8365ea1b1aa9363a3c6445745b002324 (patch) | |
| tree | 101363a56893db15b7aeaf90d074f8c4b438f138 /src/platform/posix/posix_atomic.c | |
| parent | 111b241473ceeecee1f1c232d3c9879fb850361d (diff) | |
| download | nng-eee06d1e8365ea1b1aa9363a3c6445745b002324.tar.gz nng-eee06d1e8365ea1b1aa9363a3c6445745b002324.tar.bz2 nng-eee06d1e8365ea1b1aa9363a3c6445745b002324.zip | |
Provide atomic pointer support.
This is initially used for TLS to make loading the engine pointer
faster, eliminating a much more expensive lock operation.
Diffstat (limited to 'src/platform/posix/posix_atomic.c')
| -rw-r--r-- | src/platform/posix/posix_atomic.c | 34 |
1 files changed, 32 insertions, 2 deletions
diff --git a/src/platform/posix/posix_atomic.c b/src/platform/posix/posix_atomic.c index 57ef709a..e4da9e77 100644 --- a/src/platform/posix/posix_atomic.c +++ b/src/platform/posix/posix_atomic.c @@ -1,5 +1,5 @@ // -// Copyright 2020 Staysail Systems, Inc. <info@staysail.tech> +// Copyright 2021 Staysail Systems, Inc. <info@staysail.tech> // Copyright 2018 Capitar IT Group BV <info@capitar.com> // // This software is supplied under the terms of the MIT License, a @@ -81,7 +81,19 @@ nni_atomic_get(nni_atomic_int *v) void nni_atomic_set(nni_atomic_int *v, int i) { - return (atomic_store(&v->v, i)); + atomic_store(&v->v, i); +} + +void * +nni_atomic_get_ptr(nni_atomic_ptr *v) +{ + return ((void *) atomic_load(&v->v)); +} + +void +nni_atomic_set_ptr(nni_atomic_ptr *v, void *p) +{ + atomic_store(&v->v, (uintptr_t) p); } int @@ -363,6 +375,24 @@ nni_atomic_set(nni_atomic_int *v, int i) pthread_mutex_unlock(&plat_atomic_lock); } +void * +nni_atomic_get_ptr(nni_atomic_atomic *v) +{ + void *p; + pthread_mutex_lock(&plat_atomic_lock); + p = v->v; + pthread_mutex_unlock(&plat_atomic_lock); + return (p); +} + +void +nni_atomic_set_ptr(nni_atomic_atomic *v, void *p) +{ + pthread_mutex_lock(&plat_atomic_lock); + v->v = p; + pthread_mutex_unlock(&plat_atomic_lock); +} + int nni_atomic_swap(nni_atomic_int *v, int i) { |
