4 * Copyright 2010 (c) - Mathieu Desnoyers <mathieu.desnoyers@efficios.com>
6 * Holds LTTng probes registry.
8 * Dual LGPL v2.1/GPL v2 license.
13 #include <urcu/list.h>
14 #include <urcu/hlist.h>
15 #include <lttng/ust-events.h>
16 #include <lttng/tracepoint.h>
17 #include "tracepoint-internal.h"
22 #include "ltt-tracer-core.h"
27 * probe list is protected by ust_lock()/ust_unlock().
29 static CDS_LIST_HEAD(probe_list
);
32 const struct lttng_probe_desc
*find_provider(const char *provider
)
34 struct lttng_probe_desc
*iter
;
36 cds_list_for_each_entry(iter
, &probe_list
, head
) {
37 if (!strcmp(iter
->provider
, provider
))
44 const struct lttng_event_desc
*find_event(const char *name
)
46 struct lttng_probe_desc
*probe_desc
;
49 cds_list_for_each_entry(probe_desc
, &probe_list
, head
) {
50 for (i
= 0; i
< probe_desc
->nr_events
; i
++) {
51 if (!strncmp(probe_desc
->event_desc
[i
]->name
, name
,
52 LTTNG_UST_SYM_NAME_LEN
- 1))
53 return probe_desc
->event_desc
[i
];
59 int ltt_probe_register(struct lttng_probe_desc
*desc
)
61 struct lttng_probe_desc
*iter
;
66 if (find_provider(desc
->provider
)) {
71 * TODO: This is O(N^2). Turn into a hash table when probe registration
72 * overhead becomes an issue.
74 for (i
= 0; i
< desc
->nr_events
; i
++) {
75 if (find_event(desc
->event_desc
[i
]->name
)) {
82 * We sort the providers by struct lttng_probe_desc pointer
85 cds_list_for_each_entry_reverse(iter
, &probe_list
, head
) {
86 BUG_ON(iter
== desc
); /* Should never be in the list twice */
88 /* We belong to the location right after iter. */
89 cds_list_add(&desc
->head
, &iter
->head
);
93 /* We should be added at the head of the list */
94 cds_list_add(&desc
->head
, &probe_list
);
96 DBG("just registered probe %s containing %u events",
97 desc
->provider
, desc
->nr_events
);
99 * fix the events awaiting probe load.
101 for (i
= 0; i
< desc
->nr_events
; i
++) {
102 ret
= pending_probe_fix_events(desc
->event_desc
[i
]);
110 void ltt_probe_unregister(struct lttng_probe_desc
*desc
)
113 cds_list_del(&desc
->head
);
114 DBG("just unregistered probe %s", desc
->provider
);
119 * called with UST lock held.
121 const struct lttng_event_desc
*ltt_event_get(const char *name
)
123 const struct lttng_event_desc
*event
;
125 event
= find_event(name
);
131 void ltt_event_put(const struct lttng_event_desc
*event
)
135 void ltt_probes_prune_event_list(struct lttng_ust_tracepoint_list
*list
)
137 struct tp_list_entry
*list_entry
, *tmp
;
139 cds_list_for_each_entry_safe(list_entry
, tmp
, &list
->head
, head
) {
140 cds_list_del(&list_entry
->head
);
146 * called with UST lock held.
148 int ltt_probes_get_event_list(struct lttng_ust_tracepoint_list
*list
)
150 struct lttng_probe_desc
*probe_desc
;
153 CDS_INIT_LIST_HEAD(&list
->head
);
154 cds_list_for_each_entry(probe_desc
, &probe_list
, head
) {
155 for (i
= 0; i
< probe_desc
->nr_events
; i
++) {
156 struct tp_list_entry
*list_entry
;
158 list_entry
= zmalloc(sizeof(*list_entry
));
161 cds_list_add(&list_entry
->head
, &list
->head
);
162 strncpy(list_entry
->tp
.name
,
163 probe_desc
->event_desc
[i
]->name
,
164 LTTNG_UST_SYM_NAME_LEN
);
165 list_entry
->tp
.name
[LTTNG_UST_SYM_NAME_LEN
- 1] = '\0';
166 if (!probe_desc
->event_desc
[i
]->loglevel
) {
167 list_entry
->tp
.loglevel
= TRACE_DEFAULT
;
169 list_entry
->tp
.loglevel
= *(*probe_desc
->event_desc
[i
]->loglevel
);
173 if (cds_list_empty(&list
->head
))
177 cds_list_first_entry(&list
->head
, struct tp_list_entry
, head
);
181 ltt_probes_prune_event_list(list
);
186 * Return current iteration position, advance internal iterator to next.
187 * Return NULL if end of list.
189 struct lttng_ust_tracepoint_iter
*
190 lttng_ust_tracepoint_list_get_iter_next(struct lttng_ust_tracepoint_list
*list
)
192 struct tp_list_entry
*entry
;
197 if (entry
->head
.next
== &list
->head
)
200 list
->iter
= cds_list_entry(entry
->head
.next
,
201 struct tp_list_entry
, head
);
206 * marshall all probes/all events and create those that fit the
207 * wildcard. Add them to the events list as created.
209 void ltt_probes_create_wildcard_events(struct wildcard_entry
*entry
,
210 struct session_wildcard
*wildcard
)
212 struct lttng_probe_desc
*probe_desc
;
213 struct lttng_ust_event event_param
;
216 cds_list_for_each_entry(probe_desc
, &probe_list
, head
) {
217 for (i
= 0; i
< probe_desc
->nr_events
; i
++) {
218 const struct lttng_event_desc
*event_desc
;
221 event_desc
= probe_desc
->event_desc
[i
];
222 /* compare excluding final '*' */
223 assert(strlen(entry
->name
) > 0);
224 if (strcmp(event_desc
->name
, "lttng_ust:metadata")
225 && (strlen(entry
->name
) == 1
226 || !strncmp(event_desc
->name
, entry
->name
,
227 strlen(entry
->name
) - 1))) {
228 if (ltt_loglevel_match(event_desc
,
229 entry
->loglevel_type
,
235 struct ltt_event
*ev
;
238 memcpy(&event_param
, &wildcard
->event_param
,
239 sizeof(event_param
));
240 memcpy(event_param
.name
,
242 sizeof(event_param
.name
));
244 ret
= ltt_event_create(wildcard
->chan
,
248 DBG("Error creating event");
251 cds_list_add(&ev
->wildcard_list
,