git://git.onelab.eu
/
sliver-openvswitch.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
clang: Add annotations for thread safety check.
[sliver-openvswitch.git]
/
vswitchd
/
system-stats.c
diff --git
a/vswitchd/system-stats.c
b/vswitchd/system-stats.c
index
b164228
..
9e3d228
100644
(file)
--- a/
vswitchd/system-stats.c
+++ b/
vswitchd/system-stats.c
@@
-506,12
+506,12
@@
get_filesys_stats(struct smap *stats OVS_UNUSED)
\f
#define SYSTEM_STATS_INTERVAL (5 * 1000) /* In milliseconds. */
\f
#define SYSTEM_STATS_INTERVAL (5 * 1000) /* In milliseconds. */
-static
pthread_mutex_t mutex = PTHREAD
_ADAPTIVE_MUTEX_INITIALIZER;
+static
struct ovs_mutex mutex = OVS
_ADAPTIVE_MUTEX_INITIALIZER;
static pthread_cond_t cond = PTHREAD_COND_INITIALIZER;
static pthread_cond_t cond = PTHREAD_COND_INITIALIZER;
-static struct latch latch;
+static struct latch latch
OVS_GUARDED_BY(mutex)
;
static bool enabled;
static bool enabled;
-static bool started;
-static struct smap *system_stats;
+static bool started
OVS_GUARDED_BY(mutex)
;
+static struct smap *system_stats
OVS_GUARDED_BY(mutex)
;
static void *system_stats_thread_func(void *);
static void discard_stats(void);
static void *system_stats_thread_func(void *);
static void discard_stats(void);
@@
-521,7
+521,7
@@
void
system_stats_enable(bool enable)
{
if (enabled != enable) {
system_stats_enable(bool enable)
{
if (enabled != enable) {
-
xpthread
_mutex_lock(&mutex);
+
ovs
_mutex_lock(&mutex);
if (enable) {
if (!started) {
xpthread_create(NULL, NULL, system_stats_thread_func, NULL);
if (enable) {
if (!started) {
xpthread_create(NULL, NULL, system_stats_thread_func, NULL);
@@
-532,7
+532,7
@@
system_stats_enable(bool enable)
xpthread_cond_signal(&cond);
}
enabled = enable;
xpthread_cond_signal(&cond);
}
enabled = enable;
-
xpthread
_mutex_unlock(&mutex);
+
ovs
_mutex_unlock(&mutex);
}
}
}
}
@@
-549,7
+549,7
@@
system_stats_run(void)
{
struct smap *stats = NULL;
{
struct smap *stats = NULL;
-
xpthread
_mutex_lock(&mutex);
+
ovs
_mutex_lock(&mutex);
if (system_stats) {
latch_poll(&latch);
if (system_stats) {
latch_poll(&latch);
@@
-560,7
+560,7
@@
system_stats_run(void)
discard_stats();
}
}
discard_stats();
}
}
-
xpthread
_mutex_unlock(&mutex);
+
ovs
_mutex_unlock(&mutex);
return stats;
}
return stats;
}
@@
-576,7
+576,7
@@
system_stats_wait(void)
}
static void
}
static void
-discard_stats(void)
+discard_stats(void)
OVS_REQUIRES(&mutex)
{
if (system_stats) {
smap_destroy(system_stats);
{
if (system_stats) {
smap_destroy(system_stats);
@@
-594,11
+594,11
@@
system_stats_thread_func(void *arg OVS_UNUSED)
long long int next_refresh;
struct smap *stats;
long long int next_refresh;
struct smap *stats;
-
xpthread
_mutex_lock(&mutex);
+
ovs
_mutex_lock(&mutex);
while (!enabled) {
while (!enabled) {
-
xpthread
_cond_wait(&cond, &mutex);
+
ovs_mutex
_cond_wait(&cond, &mutex);
}
}
-
xpthread
_mutex_unlock(&mutex);
+
ovs
_mutex_unlock(&mutex);
stats = xmalloc(sizeof *stats);
smap_init(stats);
stats = xmalloc(sizeof *stats);
smap_init(stats);
@@
-608,11
+608,11
@@
system_stats_thread_func(void *arg OVS_UNUSED)
get_process_stats(stats);
get_filesys_stats(stats);
get_process_stats(stats);
get_filesys_stats(stats);
-
xpthread
_mutex_lock(&mutex);
+
ovs
_mutex_lock(&mutex);
discard_stats();
system_stats = stats;
latch_set(&latch);
discard_stats();
system_stats = stats;
latch_set(&latch);
-
xpthread
_mutex_unlock(&mutex);
+
ovs
_mutex_unlock(&mutex);
next_refresh = time_msec() + SYSTEM_STATS_INTERVAL;
do {
next_refresh = time_msec() + SYSTEM_STATS_INTERVAL;
do {