projects
/
urcu.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
atomic ppc: fix missing casts and inline
[urcu.git]
/
urcu.c
diff --git
a/urcu.c
b/urcu.c
index b71e162b3fca1e29f83e02b6cd405e68b154147e..a8f85c6f02199d4ecdfb20b1a0098cef213c138c 100644
(file)
--- a/
urcu.c
+++ b/
urcu.c
@@
-36,17
+36,23
@@
/* Do not #define _LGPL_SOURCE to ensure we can emit the wrapper symbols */
#include "urcu.h"
/* Do not #define _LGPL_SOURCE to ensure we can emit the wrapper symbols */
#include "urcu.h"
+#ifndef URCU_MB
void __attribute__((constructor)) urcu_init(void);
void __attribute__((destructor)) urcu_exit(void);
void __attribute__((constructor)) urcu_init(void);
void __attribute__((destructor)) urcu_exit(void);
+#else
+void urcu_init(void)
+{
+}
+#endif
-int init_done;
+
static
int init_done;
-pthread_mutex_t urcu_mutex = PTHREAD_MUTEX_INITIALIZER;
+
static
pthread_mutex_t urcu_mutex = PTHREAD_MUTEX_INITIALIZER;
/*
* Global grace period counter.
* Contains the current RCU_GP_CTR_BIT.
/*
* Global grace period counter.
* Contains the current RCU_GP_CTR_BIT.
- * Also has a RCU_GP_C
TR_BI
T of 1, to accelerate the reader fast path.
+ * Also has a RCU_GP_C
OUN
T of 1, to accelerate the reader fast path.
* Written to only by writer with mutex taken. Read by both writer and readers.
*/
long urcu_gp_ctr = RCU_GP_COUNT;
* Written to only by writer with mutex taken. Read by both writer and readers.
*/
long urcu_gp_ctr = RCU_GP_COUNT;
@@
-75,7
+81,7
@@
static struct reader_registry *registry;
static char __thread need_mb;
static int num_readers, alloc_readers;
static char __thread need_mb;
static int num_readers, alloc_readers;
-void internal_urcu_lock(void)
+
static
void internal_urcu_lock(void)
{
int ret;
{
int ret;
@@
-102,7
+108,7
@@
void internal_urcu_lock(void)
#endif /* #else #ifndef DISTRUST_SIGNALS_EXTREME */
}
#endif /* #else #ifndef DISTRUST_SIGNALS_EXTREME */
}
-void internal_urcu_unlock(void)
+
static
void internal_urcu_unlock(void)
{
int ret;
{
int ret;
@@
-121,7
+127,7
@@
static void switch_next_urcu_qparity(void)
STORE_SHARED(urcu_gp_ctr, urcu_gp_ctr ^ RCU_GP_CTR_BIT);
}
STORE_SHARED(urcu_gp_ctr, urcu_gp_ctr ^ RCU_GP_CTR_BIT);
}
-#ifdef
DEBUG_FULL
_MB
+#ifdef
URCU
_MB
#ifdef HAS_INCOHERENT_CACHES
static void force_mb_single_thread(struct reader_registry *index)
{
#ifdef HAS_INCOHERENT_CACHES
static void force_mb_single_thread(struct reader_registry *index)
{
@@
-133,7
+139,7
@@
static void force_mb_all_threads(void)
{
smp_mb();
}
{
smp_mb();
}
-#else /* #ifdef
DEBUG_FULL
_MB */
+#else /* #ifdef
URCU
_MB */
#ifdef HAS_INCOHERENT_CACHES
static void force_mb_single_thread(struct reader_registry *index)
{
#ifdef HAS_INCOHERENT_CACHES
static void force_mb_single_thread(struct reader_registry *index)
{
@@
-200,7
+206,7
@@
static void force_mb_all_threads(void)
}
smp_mb(); /* read ->need_mb before ending the barrier */
}
}
smp_mb(); /* read ->need_mb before ending the barrier */
}
-#endif /* #else #ifdef
DEBUG_FULL
_MB */
+#endif /* #else #ifdef
URCU
_MB */
void wait_for_quiescent_state(void)
{
void wait_for_quiescent_state(void)
{
@@
-341,6
+347,12
@@
void *rcu_xchg_pointer_sym(void **p, void *v)
return xchg(p, v);
}
return xchg(p, v);
}
+void *rcu_cmpxchg_pointer_sym(void **p, void *old, void *_new)
+{
+ wmb();
+ return cmpxchg(p, old, _new);
+}
+
void *rcu_publish_content_sym(void **p, void *v)
{
void *oldptr;
void *rcu_publish_content_sym(void **p, void *v)
{
void *oldptr;
@@
-414,7
+426,7
@@
void rcu_unregister_thread(void)
internal_urcu_unlock();
}
internal_urcu_unlock();
}
-#ifndef
DEBUG_FULL
_MB
+#ifndef
URCU
_MB
static void sigurcu_handler(int signo, siginfo_t *siginfo, void *context)
{
/*
static void sigurcu_handler(int signo, siginfo_t *siginfo, void *context)
{
/*
@@
-445,6
+457,8
@@
void urcu_init(void)
init_done = 1;
act.sa_sigaction = sigurcu_handler;
init_done = 1;
act.sa_sigaction = sigurcu_handler;
+ act.sa_flags = SA_SIGINFO | SA_RESTART;
+ sigemptyset(&act.sa_mask);
ret = sigaction(SIGURCU, &act, NULL);
if (ret) {
perror("Error in sigaction");
ret = sigaction(SIGURCU, &act, NULL);
if (ret) {
perror("Error in sigaction");
@@
-465,4
+479,4
@@
void urcu_exit(void)
assert(act.sa_sigaction == sigurcu_handler);
free(registry);
}
assert(act.sa_sigaction == sigurcu_handler);
free(registry);
}
-#endif /* #ifndef
DEBUG_FULL
_MB */
+#endif /* #ifndef
URCU
_MB */
This page took
0.027366 seconds
and
4
git commands to generate.