aboutsummaryrefslogtreecommitdiff
path: root/src/platform/posix
diff options
context:
space:
mode:
authorGarrett D'Amore <garrett@damore.org>2021-12-05 17:28:40 -0500
committerGarrett D'Amore <garrett@damore.org>2021-12-05 17:28:40 -0500
commiteee06d1e8365ea1b1aa9363a3c6445745b002324 (patch)
tree101363a56893db15b7aeaf90d074f8c4b438f138 /src/platform/posix
parent111b241473ceeecee1f1c232d3c9879fb850361d (diff)
downloadnng-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')
-rw-r--r--src/platform/posix/posix_atomic.c34
-rw-r--r--src/platform/posix/posix_impl.h10
2 files changed, 41 insertions, 3 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)
{
diff --git a/src/platform/posix/posix_impl.h b/src/platform/posix/posix_impl.h
index 851c80dc..234d1501 100644
--- a/src/platform/posix/posix_impl.h
+++ b/src/platform/posix/posix_impl.h
@@ -64,7 +64,7 @@ struct nni_rwlock {
struct nni_plat_cv {
pthread_cond_t cv;
- nni_plat_mtx * mtx;
+ nni_plat_mtx *mtx;
};
struct nni_plat_thr {
@@ -99,6 +99,10 @@ struct nni_atomic_bool {
atomic_bool v;
};
+struct nni_atomic_ptr {
+ atomic_uintptr_t v;
+};
+
#else // NNG_HAVE_C11_ATOMIC
struct nni_atomic_flag {
bool f;
@@ -116,6 +120,10 @@ struct nni_atomic_u64 {
uint64_t v;
};
+struct nni_atomic_ptr {
+ void *v;
+};
+
#endif
#endif