projects
/
lttng-tools.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Enforce documented RCU preconditions with assertions
[lttng-tools.git]
/
src
/
bin
/
lttng-sessiond
/
agent.cpp
diff --git
a/src/bin/lttng-sessiond/agent.cpp
b/src/bin/lttng-sessiond/agent.cpp
index 620ec787f01833b9ed1e9d9899d3d8755fe44397..b0ac94b1300a11e98fc83683028c149887419d56 100644
(file)
--- a/
src/bin/lttng-sessiond/agent.cpp
+++ b/
src/bin/lttng-sessiond/agent.cpp
@@
-1003,6
+1003,7
@@
struct agent_app *agent_find_app_by_sock(int sock)
struct agent_app *app;
LTTNG_ASSERT(sock >= 0);
struct agent_app *app;
LTTNG_ASSERT(sock >= 0);
+ ASSERT_RCU_READ_LOCKED();
lttng_ht_lookup(the_agent_apps_ht_by_sock,
(void *) ((unsigned long) sock), &iter);
lttng_ht_lookup(the_agent_apps_ht_by_sock,
(void *) ((unsigned long) sock), &iter);
@@
-1042,6
+1043,7
@@
void agent_delete_app(struct agent_app *app)
struct lttng_ht_iter iter;
LTTNG_ASSERT(app);
struct lttng_ht_iter iter;
LTTNG_ASSERT(app);
+ ASSERT_RCU_READ_LOCKED();
DBG3("Agent deleting app pid: %d and sock: %d", app->pid, app->sock->fd);
DBG3("Agent deleting app pid: %d and sock: %d", app->pid, app->sock->fd);
@@
-1229,6
+1231,7
@@
void agent_find_events_by_name(const char *name, struct agent *agt,
LTTNG_ASSERT(agt);
LTTNG_ASSERT(agt->events);
LTTNG_ASSERT(iter);
LTTNG_ASSERT(agt);
LTTNG_ASSERT(agt->events);
LTTNG_ASSERT(iter);
+ ASSERT_RCU_READ_LOCKED();
ht = agt->events;
key.name = name;
ht = agt->events;
key.name = name;
@@
-1264,6
+1267,7
@@
struct agent_event *agent_find_event_by_trigger(
LTTNG_ASSERT(agt);
LTTNG_ASSERT(agt->events);
LTTNG_ASSERT(agt);
LTTNG_ASSERT(agt->events);
+ ASSERT_RCU_READ_LOCKED();
condition = lttng_trigger_get_const_condition(trigger);
condition = lttng_trigger_get_const_condition(trigger);
@@
-1336,6
+1340,8
@@
void agent_event_next_duplicate(const char *name,
{
struct agent_ht_key key;
{
struct agent_ht_key key;
+ ASSERT_RCU_READ_LOCKED();
+
key.name = name;
cds_lfht_next_duplicate(agt->events->ht, ht_match_event_by_name,
key.name = name;
cds_lfht_next_duplicate(agt->events->ht, ht_match_event_by_name,
@@
-1364,6
+1370,7
@@
struct agent_event *agent_find_event(const char *name,
LTTNG_ASSERT(name);
LTTNG_ASSERT(agt);
LTTNG_ASSERT(agt->events);
LTTNG_ASSERT(name);
LTTNG_ASSERT(agt);
LTTNG_ASSERT(agt->events);
+ ASSERT_RCU_READ_LOCKED();
ht = agt->events;
key.name = name;
ht = agt->events;
key.name = name;
This page took
0.024535 seconds
and
4
git commands to generate.