#include <urcu/rculist.h>
#include <lttng/event-rule/event-rule.h>
-#include <lttng/event-rule/event-rule-internal.h>
+#include <lttng/event-rule/event-rule-internal.hpp>
#include <lttng/event-rule/jul-logging.h>
#include <lttng/event-rule/log4j-logging.h>
#include <lttng/event-rule/python-logging.h>
#include <lttng/condition/condition.h>
#include <lttng/condition/event-rule-matches.h>
-#include <lttng/domain-internal.h>
-#include <lttng/log-level-rule-internal.h>
+#include <lttng/domain-internal.hpp>
+#include <lttng/log-level-rule-internal.hpp>
-#include <common/common.h>
-#include <common/sessiond-comm/agent.h>
+#include <common/common.hpp>
+#include <common/sessiond-comm/agent.hpp>
-#include <common/compat/endian.h>
+#include <common/compat/endian.hpp>
-#include "agent.h"
-#include "ust-app.h"
-#include "utils.h"
-#include "common/error.h"
+#include "agent.hpp"
+#include "ust-app.hpp"
+#include "utils.hpp"
+#include "common/error.hpp"
typedef enum lttng_event_rule_status (*event_rule_logging_get_name_pattern)(
const struct lttng_event_rule *rule, const char **pattern);
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);
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);
LTTNG_ASSERT(agt);
LTTNG_ASSERT(agt->events);
LTTNG_ASSERT(iter);
+ ASSERT_RCU_READ_LOCKED();
ht = agt->events;
key.name = name;
LTTNG_ASSERT(agt);
LTTNG_ASSERT(agt->events);
+ ASSERT_RCU_READ_LOCKED();
condition = lttng_trigger_get_const_condition(trigger);
{
struct agent_ht_key key;
+ ASSERT_RCU_READ_LOCKED();
+
key.name = name;
cds_lfht_next_duplicate(agt->events->ht, ht_match_event_by_name,
LTTNG_ASSERT(name);
LTTNG_ASSERT(agt);
LTTNG_ASSERT(agt->events);
+ ASSERT_RCU_READ_LOCKED();
ht = agt->events;
key.name = name;