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 const struct lttng_event_desc
*ed
;
104 ed
= desc
->event_desc
[i
];
105 DBG("Registered event probe \"%s\" with signature \"%s\"",
106 ed
->name
, ed
->signature
);
107 ret
= pending_probe_fix_events(ed
);
115 void ltt_probe_unregister(struct lttng_probe_desc
*desc
)
118 cds_list_del(&desc
->head
);
119 DBG("just unregistered probe %s", desc
->provider
);
124 * called with UST lock held.
126 const struct lttng_event_desc
*ltt_event_get(const char *name
)
128 const struct lttng_event_desc
*event
;
130 event
= find_event(name
);
136 void ltt_event_put(const struct lttng_event_desc
*event
)
140 void ltt_probes_prune_event_list(struct lttng_ust_tracepoint_list
*list
)
142 struct tp_list_entry
*list_entry
, *tmp
;
144 cds_list_for_each_entry_safe(list_entry
, tmp
, &list
->head
, head
) {
145 cds_list_del(&list_entry
->head
);
151 * called with UST lock held.
153 int ltt_probes_get_event_list(struct lttng_ust_tracepoint_list
*list
)
155 struct lttng_probe_desc
*probe_desc
;
158 CDS_INIT_LIST_HEAD(&list
->head
);
159 cds_list_for_each_entry(probe_desc
, &probe_list
, head
) {
160 for (i
= 0; i
< probe_desc
->nr_events
; i
++) {
161 struct tp_list_entry
*list_entry
;
163 list_entry
= zmalloc(sizeof(*list_entry
));
166 cds_list_add(&list_entry
->head
, &list
->head
);
167 strncpy(list_entry
->tp
.name
,
168 probe_desc
->event_desc
[i
]->name
,
169 LTTNG_UST_SYM_NAME_LEN
);
170 list_entry
->tp
.name
[LTTNG_UST_SYM_NAME_LEN
- 1] = '\0';
171 if (!probe_desc
->event_desc
[i
]->loglevel
) {
172 list_entry
->tp
.loglevel
= TRACE_DEFAULT
;
174 list_entry
->tp
.loglevel
= *(*probe_desc
->event_desc
[i
]->loglevel
);
178 if (cds_list_empty(&list
->head
))
182 cds_list_first_entry(&list
->head
, struct tp_list_entry
, head
);
186 ltt_probes_prune_event_list(list
);
191 * Return current iteration position, advance internal iterator to next.
192 * Return NULL if end of list.
194 struct lttng_ust_tracepoint_iter
*
195 lttng_ust_tracepoint_list_get_iter_next(struct lttng_ust_tracepoint_list
*list
)
197 struct tp_list_entry
*entry
;
202 if (entry
->head
.next
== &list
->head
)
205 list
->iter
= cds_list_entry(entry
->head
.next
,
206 struct tp_list_entry
, head
);
211 * marshall all probes/all events and create those that fit the
212 * wildcard. Add them to the events list as created.
214 void ltt_probes_create_wildcard_events(struct wildcard_entry
*entry
,
215 struct session_wildcard
*wildcard
)
217 struct lttng_probe_desc
*probe_desc
;
218 struct lttng_ust_event event_param
;
221 cds_list_for_each_entry(probe_desc
, &probe_list
, head
) {
222 for (i
= 0; i
< probe_desc
->nr_events
; i
++) {
223 const struct lttng_event_desc
*event_desc
;
226 event_desc
= probe_desc
->event_desc
[i
];
227 /* compare excluding final '*' */
228 assert(strlen(entry
->name
) > 0);
229 if (strcmp(event_desc
->name
, "lttng_ust:metadata")
230 && (strlen(entry
->name
) == 1
231 || !strncmp(event_desc
->name
, entry
->name
,
232 strlen(entry
->name
) - 1))) {
233 if (ltt_loglevel_match(event_desc
,
234 entry
->loglevel_type
,
240 struct ltt_event
*ev
;
243 memcpy(&event_param
, &wildcard
->event_param
,
244 sizeof(event_param
));
245 memcpy(event_param
.name
,
247 sizeof(event_param
.name
));
249 ret
= ltt_event_create(wildcard
->chan
,
253 DBG("Error creating event");
256 cds_list_add(&ev
->wildcard_list
,