#include <string.h>
#include <errno.h>
#include <urcu/list.h>
+#include <urcu/hlist.h>
#include <lttng/ust-events.h>
#include <assert.h>
#include <helper.h>
+#include <ctype.h>
+#include "tracepoint-internal.h"
#include "ltt-tracer-core.h"
+#include "jhash.h"
+#include "error.h"
/*
* probe list is protected by ust_lock()/ust_unlock().
cds_list_for_each_entry(probe_desc, &probe_list, head) {
for (i = 0; i < probe_desc->nr_events; i++) {
- if (!strcmp(probe_desc->event_desc[i]->name, name))
+ if (!strncmp(probe_desc->event_desc[i]->name, name,
+ LTTNG_UST_SYM_NAME_LEN - 1))
return probe_desc->event_desc[i];
}
}
/* We should be added at the head of the list */
cds_list_add(&desc->head, &probe_list);
desc_added:
-
+ DBG("just registered probe %s containing %u events",
+ desc->provider, desc->nr_events);
/*
* fix the events awaiting probe load.
*/
{
ust_lock();
cds_list_del(&desc->head);
+ DBG("just unregistered probe %s", desc->provider);
ust_unlock();
}
LTTNG_UST_SYM_NAME_LEN);
list_entry->tp.name[LTTNG_UST_SYM_NAME_LEN - 1] = '\0';
if (!probe_desc->event_desc[i]->loglevel) {
- list_entry->tp.loglevel[0] = '\0';
- list_entry->tp.loglevel_value = 0;
+ list_entry->tp.loglevel = TRACE_DEFAULT;
} else {
- strncpy(list_entry->tp.loglevel,
- (*probe_desc->event_desc[i]->loglevel)->identifier,
- LTTNG_UST_SYM_NAME_LEN);
- list_entry->tp.loglevel[LTTNG_UST_SYM_NAME_LEN - 1] = '\0';
- list_entry->tp.loglevel_value =
- (*probe_desc->event_desc[i]->loglevel)->value;
+ list_entry->tp.loglevel = *(*probe_desc->event_desc[i]->loglevel);
}
}
}
struct tp_list_entry, head);
return &entry->tp;
}
+
+/*
+ * marshall all probes/all events and create those that fit the
+ * wildcard. Add them to the events list as created.
+ */
+void ltt_probes_create_wildcard_events(struct wildcard_entry *entry,
+ struct session_wildcard *wildcard)
+{
+ struct lttng_probe_desc *probe_desc;
+ struct lttng_ust_event event_param;
+ int i;
+
+ cds_list_for_each_entry(probe_desc, &probe_list, head) {
+ for (i = 0; i < probe_desc->nr_events; i++) {
+ const struct lttng_event_desc *event_desc;
+ int match = 0;
+
+ event_desc = probe_desc->event_desc[i];
+ /* compare excluding final '*' */
+ assert(strlen(entry->name) > 0);
+ if (strcmp(event_desc->name, "lttng_ust:metadata")
+ && (strlen(entry->name) == 1
+ || !strncmp(event_desc->name, entry->name,
+ strlen(entry->name) - 1))) {
+ if (ltt_loglevel_match(event_desc,
+ entry->loglevel_type,
+ entry->loglevel)) {
+ match = 1;
+ }
+ }
+ if (match) {
+ struct ltt_event *ev;
+ int ret;
+
+ memcpy(&event_param, &wildcard->event_param,
+ sizeof(event_param));
+ memcpy(event_param.name,
+ event_desc->name,
+ sizeof(event_param.name));
+ /* create event */
+ ret = ltt_event_create(wildcard->chan,
+ &event_param, NULL,
+ &ev);
+ if (ret) {
+ DBG("Error creating event");
+ continue;
+ }
+ cds_list_add(&ev->wildcard_list,
+ &wildcard->events);
+ }
+ }
+ }
+}
+