.. | .. |
---|
7 | 7 | */ |
---|
8 | 8 | #define pr_fmt(fmt) "trace_kprobe: " fmt |
---|
9 | 9 | |
---|
| 10 | +#include <linux/security.h> |
---|
10 | 11 | #include <linux/module.h> |
---|
11 | 12 | #include <linux/uaccess.h> |
---|
12 | 13 | #include <linux/rculist.h> |
---|
13 | 14 | #include <linux/error-injection.h> |
---|
14 | 15 | |
---|
| 16 | +#include <asm/setup.h> /* for COMMAND_LINE_SIZE */ |
---|
| 17 | + |
---|
| 18 | +#include "trace_dynevent.h" |
---|
15 | 19 | #include "trace_kprobe_selftest.h" |
---|
16 | 20 | #include "trace_probe.h" |
---|
| 21 | +#include "trace_probe_tmpl.h" |
---|
17 | 22 | |
---|
18 | 23 | #define KPROBE_EVENT_SYSTEM "kprobes" |
---|
19 | 24 | #define KRETPROBE_MAXACTIVE_MAX 4096 |
---|
20 | 25 | |
---|
21 | | -/** |
---|
| 26 | +/* Kprobe early definition from command line */ |
---|
| 27 | +static char kprobe_boot_events_buf[COMMAND_LINE_SIZE] __initdata; |
---|
| 28 | + |
---|
| 29 | +static int __init set_kprobe_boot_events(char *str) |
---|
| 30 | +{ |
---|
| 31 | + strlcpy(kprobe_boot_events_buf, str, COMMAND_LINE_SIZE); |
---|
| 32 | + disable_tracing_selftest("running kprobe events"); |
---|
| 33 | + |
---|
| 34 | + return 1; |
---|
| 35 | +} |
---|
| 36 | +__setup("kprobe_event=", set_kprobe_boot_events); |
---|
| 37 | + |
---|
| 38 | +static int trace_kprobe_create(int argc, const char **argv); |
---|
| 39 | +static int trace_kprobe_show(struct seq_file *m, struct dyn_event *ev); |
---|
| 40 | +static int trace_kprobe_release(struct dyn_event *ev); |
---|
| 41 | +static bool trace_kprobe_is_busy(struct dyn_event *ev); |
---|
| 42 | +static bool trace_kprobe_match(const char *system, const char *event, |
---|
| 43 | + int argc, const char **argv, struct dyn_event *ev); |
---|
| 44 | + |
---|
| 45 | +static struct dyn_event_operations trace_kprobe_ops = { |
---|
| 46 | + .create = trace_kprobe_create, |
---|
| 47 | + .show = trace_kprobe_show, |
---|
| 48 | + .is_busy = trace_kprobe_is_busy, |
---|
| 49 | + .free = trace_kprobe_release, |
---|
| 50 | + .match = trace_kprobe_match, |
---|
| 51 | +}; |
---|
| 52 | + |
---|
| 53 | +/* |
---|
22 | 54 | * Kprobe event core functions |
---|
23 | 55 | */ |
---|
24 | 56 | struct trace_kprobe { |
---|
25 | | - struct list_head list; |
---|
| 57 | + struct dyn_event devent; |
---|
26 | 58 | struct kretprobe rp; /* Use rp.kp for kprobe use */ |
---|
27 | 59 | unsigned long __percpu *nhit; |
---|
28 | 60 | const char *symbol; /* symbol name */ |
---|
29 | 61 | struct trace_probe tp; |
---|
30 | 62 | }; |
---|
| 63 | + |
---|
| 64 | +static bool is_trace_kprobe(struct dyn_event *ev) |
---|
| 65 | +{ |
---|
| 66 | + return ev->ops == &trace_kprobe_ops; |
---|
| 67 | +} |
---|
| 68 | + |
---|
| 69 | +static struct trace_kprobe *to_trace_kprobe(struct dyn_event *ev) |
---|
| 70 | +{ |
---|
| 71 | + return container_of(ev, struct trace_kprobe, devent); |
---|
| 72 | +} |
---|
| 73 | + |
---|
| 74 | +/** |
---|
| 75 | + * for_each_trace_kprobe - iterate over the trace_kprobe list |
---|
| 76 | + * @pos: the struct trace_kprobe * for each entry |
---|
| 77 | + * @dpos: the struct dyn_event * to use as a loop cursor |
---|
| 78 | + */ |
---|
| 79 | +#define for_each_trace_kprobe(pos, dpos) \ |
---|
| 80 | + for_each_dyn_event(dpos) \ |
---|
| 81 | + if (is_trace_kprobe(dpos) && (pos = to_trace_kprobe(dpos))) |
---|
31 | 82 | |
---|
32 | 83 | #define SIZEOF_TRACE_KPROBE(n) \ |
---|
33 | 84 | (offsetof(struct trace_kprobe, tp.args) + \ |
---|
.. | .. |
---|
56 | 107 | static nokprobe_inline bool trace_kprobe_within_module(struct trace_kprobe *tk, |
---|
57 | 108 | struct module *mod) |
---|
58 | 109 | { |
---|
59 | | - int len = strlen(mod->name); |
---|
| 110 | + int len = strlen(module_name(mod)); |
---|
60 | 111 | const char *name = trace_kprobe_symbol(tk); |
---|
61 | | - return strncmp(mod->name, name, len) == 0 && name[len] == ':'; |
---|
| 112 | + |
---|
| 113 | + return strncmp(module_name(mod), name, len) == 0 && name[len] == ':'; |
---|
62 | 114 | } |
---|
63 | 115 | |
---|
64 | 116 | static nokprobe_inline bool trace_kprobe_module_exist(struct trace_kprobe *tk) |
---|
.. | .. |
---|
80 | 132 | return ret; |
---|
81 | 133 | } |
---|
82 | 134 | |
---|
| 135 | +static bool trace_kprobe_is_busy(struct dyn_event *ev) |
---|
| 136 | +{ |
---|
| 137 | + struct trace_kprobe *tk = to_trace_kprobe(ev); |
---|
| 138 | + |
---|
| 139 | + return trace_probe_is_enabled(&tk->tp); |
---|
| 140 | +} |
---|
| 141 | + |
---|
| 142 | +static bool trace_kprobe_match_command_head(struct trace_kprobe *tk, |
---|
| 143 | + int argc, const char **argv) |
---|
| 144 | +{ |
---|
| 145 | + char buf[MAX_ARGSTR_LEN + 1]; |
---|
| 146 | + |
---|
| 147 | + if (!argc) |
---|
| 148 | + return true; |
---|
| 149 | + |
---|
| 150 | + if (!tk->symbol) |
---|
| 151 | + snprintf(buf, sizeof(buf), "0x%p", tk->rp.kp.addr); |
---|
| 152 | + else if (tk->rp.kp.offset) |
---|
| 153 | + snprintf(buf, sizeof(buf), "%s+%u", |
---|
| 154 | + trace_kprobe_symbol(tk), tk->rp.kp.offset); |
---|
| 155 | + else |
---|
| 156 | + snprintf(buf, sizeof(buf), "%s", trace_kprobe_symbol(tk)); |
---|
| 157 | + if (strcmp(buf, argv[0])) |
---|
| 158 | + return false; |
---|
| 159 | + argc--; argv++; |
---|
| 160 | + |
---|
| 161 | + return trace_probe_match_command_args(&tk->tp, argc, argv); |
---|
| 162 | +} |
---|
| 163 | + |
---|
| 164 | +static bool trace_kprobe_match(const char *system, const char *event, |
---|
| 165 | + int argc, const char **argv, struct dyn_event *ev) |
---|
| 166 | +{ |
---|
| 167 | + struct trace_kprobe *tk = to_trace_kprobe(ev); |
---|
| 168 | + |
---|
| 169 | + return strcmp(trace_probe_name(&tk->tp), event) == 0 && |
---|
| 170 | + (!system || strcmp(trace_probe_group_name(&tk->tp), system) == 0) && |
---|
| 171 | + trace_kprobe_match_command_head(tk, argc, argv); |
---|
| 172 | +} |
---|
| 173 | + |
---|
83 | 174 | static nokprobe_inline unsigned long trace_kprobe_nhit(struct trace_kprobe *tk) |
---|
84 | 175 | { |
---|
85 | 176 | unsigned long nhit = 0; |
---|
.. | .. |
---|
89 | 180 | nhit += *per_cpu_ptr(tk->nhit, cpu); |
---|
90 | 181 | |
---|
91 | 182 | return nhit; |
---|
| 183 | +} |
---|
| 184 | + |
---|
| 185 | +static nokprobe_inline bool trace_kprobe_is_registered(struct trace_kprobe *tk) |
---|
| 186 | +{ |
---|
| 187 | + return !(list_empty(&tk->rp.kp.list) && |
---|
| 188 | + hlist_unhashed(&tk->rp.kp.hlist)); |
---|
92 | 189 | } |
---|
93 | 190 | |
---|
94 | 191 | /* Return 0 if it fails to find the symbol address */ |
---|
.. | .. |
---|
108 | 205 | return addr; |
---|
109 | 206 | } |
---|
110 | 207 | |
---|
| 208 | +static nokprobe_inline struct trace_kprobe * |
---|
| 209 | +trace_kprobe_primary_from_call(struct trace_event_call *call) |
---|
| 210 | +{ |
---|
| 211 | + struct trace_probe *tp; |
---|
| 212 | + |
---|
| 213 | + tp = trace_probe_primary_from_call(call); |
---|
| 214 | + if (WARN_ON_ONCE(!tp)) |
---|
| 215 | + return NULL; |
---|
| 216 | + |
---|
| 217 | + return container_of(tp, struct trace_kprobe, tp); |
---|
| 218 | +} |
---|
| 219 | + |
---|
111 | 220 | bool trace_kprobe_on_func_entry(struct trace_event_call *call) |
---|
112 | 221 | { |
---|
113 | | - struct trace_kprobe *tk = (struct trace_kprobe *)call->data; |
---|
| 222 | + struct trace_kprobe *tk = trace_kprobe_primary_from_call(call); |
---|
114 | 223 | |
---|
115 | | - return (kprobe_on_func_entry(tk->rp.kp.addr, |
---|
| 224 | + return tk ? (kprobe_on_func_entry(tk->rp.kp.addr, |
---|
116 | 225 | tk->rp.kp.addr ? NULL : tk->rp.kp.symbol_name, |
---|
117 | | - tk->rp.kp.addr ? 0 : tk->rp.kp.offset) == 0); |
---|
| 226 | + tk->rp.kp.addr ? 0 : tk->rp.kp.offset) == 0) : false; |
---|
118 | 227 | } |
---|
119 | 228 | |
---|
120 | 229 | bool trace_kprobe_error_injectable(struct trace_event_call *call) |
---|
121 | 230 | { |
---|
122 | | - struct trace_kprobe *tk = (struct trace_kprobe *)call->data; |
---|
| 231 | + struct trace_kprobe *tk = trace_kprobe_primary_from_call(call); |
---|
123 | 232 | |
---|
124 | | - return within_error_injection_list(trace_kprobe_address(tk)); |
---|
| 233 | + return tk ? within_error_injection_list(trace_kprobe_address(tk)) : |
---|
| 234 | + false; |
---|
125 | 235 | } |
---|
126 | 236 | |
---|
127 | 237 | static int register_kprobe_event(struct trace_kprobe *tk); |
---|
128 | 238 | static int unregister_kprobe_event(struct trace_kprobe *tk); |
---|
129 | 239 | |
---|
130 | | -static DEFINE_MUTEX(probe_lock); |
---|
131 | | -static LIST_HEAD(probe_list); |
---|
132 | | - |
---|
133 | 240 | static int kprobe_dispatcher(struct kprobe *kp, struct pt_regs *regs); |
---|
134 | 241 | static int kretprobe_dispatcher(struct kretprobe_instance *ri, |
---|
135 | 242 | struct pt_regs *regs); |
---|
136 | 243 | |
---|
137 | | -/* Memory fetching by symbol */ |
---|
138 | | -struct symbol_cache { |
---|
139 | | - char *symbol; |
---|
140 | | - long offset; |
---|
141 | | - unsigned long addr; |
---|
142 | | -}; |
---|
143 | | - |
---|
144 | | -unsigned long update_symbol_cache(struct symbol_cache *sc) |
---|
| 244 | +static void free_trace_kprobe(struct trace_kprobe *tk) |
---|
145 | 245 | { |
---|
146 | | - sc->addr = (unsigned long)kallsyms_lookup_name(sc->symbol); |
---|
147 | | - |
---|
148 | | - if (sc->addr) |
---|
149 | | - sc->addr += sc->offset; |
---|
150 | | - |
---|
151 | | - return sc->addr; |
---|
152 | | -} |
---|
153 | | - |
---|
154 | | -void free_symbol_cache(struct symbol_cache *sc) |
---|
155 | | -{ |
---|
156 | | - kfree(sc->symbol); |
---|
157 | | - kfree(sc); |
---|
158 | | -} |
---|
159 | | - |
---|
160 | | -struct symbol_cache *alloc_symbol_cache(const char *sym, long offset) |
---|
161 | | -{ |
---|
162 | | - struct symbol_cache *sc; |
---|
163 | | - |
---|
164 | | - if (!sym || strlen(sym) == 0) |
---|
165 | | - return NULL; |
---|
166 | | - |
---|
167 | | - sc = kzalloc(sizeof(struct symbol_cache), GFP_KERNEL); |
---|
168 | | - if (!sc) |
---|
169 | | - return NULL; |
---|
170 | | - |
---|
171 | | - sc->symbol = kstrdup(sym, GFP_KERNEL); |
---|
172 | | - if (!sc->symbol) { |
---|
173 | | - kfree(sc); |
---|
174 | | - return NULL; |
---|
175 | | - } |
---|
176 | | - sc->offset = offset; |
---|
177 | | - update_symbol_cache(sc); |
---|
178 | | - |
---|
179 | | - return sc; |
---|
180 | | -} |
---|
181 | | - |
---|
182 | | -/* |
---|
183 | | - * Kprobes-specific fetch functions |
---|
184 | | - */ |
---|
185 | | -#define DEFINE_FETCH_stack(type) \ |
---|
186 | | -static void FETCH_FUNC_NAME(stack, type)(struct pt_regs *regs, \ |
---|
187 | | - void *offset, void *dest) \ |
---|
188 | | -{ \ |
---|
189 | | - *(type *)dest = (type)regs_get_kernel_stack_nth(regs, \ |
---|
190 | | - (unsigned int)((unsigned long)offset)); \ |
---|
191 | | -} \ |
---|
192 | | -NOKPROBE_SYMBOL(FETCH_FUNC_NAME(stack, type)); |
---|
193 | | - |
---|
194 | | -DEFINE_BASIC_FETCH_FUNCS(stack) |
---|
195 | | -/* No string on the stack entry */ |
---|
196 | | -#define fetch_stack_string NULL |
---|
197 | | -#define fetch_stack_string_size NULL |
---|
198 | | - |
---|
199 | | -#define DEFINE_FETCH_memory(type) \ |
---|
200 | | -static void FETCH_FUNC_NAME(memory, type)(struct pt_regs *regs, \ |
---|
201 | | - void *addr, void *dest) \ |
---|
202 | | -{ \ |
---|
203 | | - type retval; \ |
---|
204 | | - if (probe_kernel_address(addr, retval)) \ |
---|
205 | | - *(type *)dest = 0; \ |
---|
206 | | - else \ |
---|
207 | | - *(type *)dest = retval; \ |
---|
208 | | -} \ |
---|
209 | | -NOKPROBE_SYMBOL(FETCH_FUNC_NAME(memory, type)); |
---|
210 | | - |
---|
211 | | -DEFINE_BASIC_FETCH_FUNCS(memory) |
---|
212 | | -/* |
---|
213 | | - * Fetch a null-terminated string. Caller MUST set *(u32 *)dest with max |
---|
214 | | - * length and relative data location. |
---|
215 | | - */ |
---|
216 | | -static void FETCH_FUNC_NAME(memory, string)(struct pt_regs *regs, |
---|
217 | | - void *addr, void *dest) |
---|
218 | | -{ |
---|
219 | | - int maxlen = get_rloc_len(*(u32 *)dest); |
---|
220 | | - u8 *dst = get_rloc_data(dest); |
---|
221 | | - long ret; |
---|
222 | | - |
---|
223 | | - if (!maxlen) |
---|
224 | | - return; |
---|
225 | | - |
---|
226 | | - /* |
---|
227 | | - * Try to get string again, since the string can be changed while |
---|
228 | | - * probing. |
---|
229 | | - */ |
---|
230 | | - ret = strncpy_from_unsafe(dst, addr, maxlen); |
---|
231 | | - |
---|
232 | | - if (ret < 0) { /* Failed to fetch string */ |
---|
233 | | - dst[0] = '\0'; |
---|
234 | | - *(u32 *)dest = make_data_rloc(0, get_rloc_offs(*(u32 *)dest)); |
---|
235 | | - } else { |
---|
236 | | - *(u32 *)dest = make_data_rloc(ret, get_rloc_offs(*(u32 *)dest)); |
---|
| 246 | + if (tk) { |
---|
| 247 | + trace_probe_cleanup(&tk->tp); |
---|
| 248 | + kfree(tk->symbol); |
---|
| 249 | + free_percpu(tk->nhit); |
---|
| 250 | + kfree(tk); |
---|
237 | 251 | } |
---|
238 | 252 | } |
---|
239 | | -NOKPROBE_SYMBOL(FETCH_FUNC_NAME(memory, string)); |
---|
240 | | - |
---|
241 | | -/* Return the length of string -- including null terminal byte */ |
---|
242 | | -static void FETCH_FUNC_NAME(memory, string_size)(struct pt_regs *regs, |
---|
243 | | - void *addr, void *dest) |
---|
244 | | -{ |
---|
245 | | - mm_segment_t old_fs; |
---|
246 | | - int ret, len = 0; |
---|
247 | | - u8 c; |
---|
248 | | - |
---|
249 | | - old_fs = get_fs(); |
---|
250 | | - set_fs(KERNEL_DS); |
---|
251 | | - pagefault_disable(); |
---|
252 | | - |
---|
253 | | - do { |
---|
254 | | - ret = __copy_from_user_inatomic(&c, (u8 *)addr + len, 1); |
---|
255 | | - len++; |
---|
256 | | - } while (c && ret == 0 && len < MAX_STRING_SIZE); |
---|
257 | | - |
---|
258 | | - pagefault_enable(); |
---|
259 | | - set_fs(old_fs); |
---|
260 | | - |
---|
261 | | - if (ret < 0) /* Failed to check the length */ |
---|
262 | | - *(u32 *)dest = 0; |
---|
263 | | - else |
---|
264 | | - *(u32 *)dest = len; |
---|
265 | | -} |
---|
266 | | -NOKPROBE_SYMBOL(FETCH_FUNC_NAME(memory, string_size)); |
---|
267 | | - |
---|
268 | | -#define DEFINE_FETCH_symbol(type) \ |
---|
269 | | -void FETCH_FUNC_NAME(symbol, type)(struct pt_regs *regs, void *data, void *dest)\ |
---|
270 | | -{ \ |
---|
271 | | - struct symbol_cache *sc = data; \ |
---|
272 | | - if (sc->addr) \ |
---|
273 | | - fetch_memory_##type(regs, (void *)sc->addr, dest); \ |
---|
274 | | - else \ |
---|
275 | | - *(type *)dest = 0; \ |
---|
276 | | -} \ |
---|
277 | | -NOKPROBE_SYMBOL(FETCH_FUNC_NAME(symbol, type)); |
---|
278 | | - |
---|
279 | | -DEFINE_BASIC_FETCH_FUNCS(symbol) |
---|
280 | | -DEFINE_FETCH_symbol(string) |
---|
281 | | -DEFINE_FETCH_symbol(string_size) |
---|
282 | | - |
---|
283 | | -/* kprobes don't support file_offset fetch methods */ |
---|
284 | | -#define fetch_file_offset_u8 NULL |
---|
285 | | -#define fetch_file_offset_u16 NULL |
---|
286 | | -#define fetch_file_offset_u32 NULL |
---|
287 | | -#define fetch_file_offset_u64 NULL |
---|
288 | | -#define fetch_file_offset_string NULL |
---|
289 | | -#define fetch_file_offset_string_size NULL |
---|
290 | | - |
---|
291 | | -/* Fetch type information table */ |
---|
292 | | -static const struct fetch_type kprobes_fetch_type_table[] = { |
---|
293 | | - /* Special types */ |
---|
294 | | - [FETCH_TYPE_STRING] = __ASSIGN_FETCH_TYPE("string", string, string, |
---|
295 | | - sizeof(u32), 1, "__data_loc char[]"), |
---|
296 | | - [FETCH_TYPE_STRSIZE] = __ASSIGN_FETCH_TYPE("string_size", u32, |
---|
297 | | - string_size, sizeof(u32), 0, "u32"), |
---|
298 | | - /* Basic types */ |
---|
299 | | - ASSIGN_FETCH_TYPE(u8, u8, 0), |
---|
300 | | - ASSIGN_FETCH_TYPE(u16, u16, 0), |
---|
301 | | - ASSIGN_FETCH_TYPE(u32, u32, 0), |
---|
302 | | - ASSIGN_FETCH_TYPE(u64, u64, 0), |
---|
303 | | - ASSIGN_FETCH_TYPE(s8, u8, 1), |
---|
304 | | - ASSIGN_FETCH_TYPE(s16, u16, 1), |
---|
305 | | - ASSIGN_FETCH_TYPE(s32, u32, 1), |
---|
306 | | - ASSIGN_FETCH_TYPE(s64, u64, 1), |
---|
307 | | - ASSIGN_FETCH_TYPE_ALIAS(x8, u8, u8, 0), |
---|
308 | | - ASSIGN_FETCH_TYPE_ALIAS(x16, u16, u16, 0), |
---|
309 | | - ASSIGN_FETCH_TYPE_ALIAS(x32, u32, u32, 0), |
---|
310 | | - ASSIGN_FETCH_TYPE_ALIAS(x64, u64, u64, 0), |
---|
311 | | - |
---|
312 | | - ASSIGN_FETCH_TYPE_END |
---|
313 | | -}; |
---|
314 | 253 | |
---|
315 | 254 | /* |
---|
316 | 255 | * Allocate new trace_probe and initialize it (including kprobes). |
---|
.. | .. |
---|
349 | 288 | tk->rp.kp.pre_handler = kprobe_dispatcher; |
---|
350 | 289 | |
---|
351 | 290 | tk->rp.maxactive = maxactive; |
---|
| 291 | + INIT_HLIST_NODE(&tk->rp.kp.hlist); |
---|
| 292 | + INIT_LIST_HEAD(&tk->rp.kp.list); |
---|
352 | 293 | |
---|
353 | | - if (!event || !is_good_name(event)) { |
---|
354 | | - ret = -EINVAL; |
---|
355 | | - goto error; |
---|
356 | | - } |
---|
357 | | - |
---|
358 | | - tk->tp.call.class = &tk->tp.class; |
---|
359 | | - tk->tp.call.name = kstrdup(event, GFP_KERNEL); |
---|
360 | | - if (!tk->tp.call.name) |
---|
| 294 | + ret = trace_probe_init(&tk->tp, event, group, false); |
---|
| 295 | + if (ret < 0) |
---|
361 | 296 | goto error; |
---|
362 | 297 | |
---|
363 | | - if (!group || !is_good_name(group)) { |
---|
364 | | - ret = -EINVAL; |
---|
365 | | - goto error; |
---|
366 | | - } |
---|
367 | | - |
---|
368 | | - tk->tp.class.system = kstrdup(group, GFP_KERNEL); |
---|
369 | | - if (!tk->tp.class.system) |
---|
370 | | - goto error; |
---|
371 | | - |
---|
372 | | - INIT_LIST_HEAD(&tk->list); |
---|
373 | | - INIT_LIST_HEAD(&tk->tp.files); |
---|
| 298 | + dyn_event_init(&tk->devent, &trace_kprobe_ops); |
---|
374 | 299 | return tk; |
---|
375 | 300 | error: |
---|
376 | | - kfree(tk->tp.call.name); |
---|
377 | | - kfree(tk->symbol); |
---|
378 | | - free_percpu(tk->nhit); |
---|
379 | | - kfree(tk); |
---|
| 301 | + free_trace_kprobe(tk); |
---|
380 | 302 | return ERR_PTR(ret); |
---|
381 | | -} |
---|
382 | | - |
---|
383 | | -static void free_trace_kprobe(struct trace_kprobe *tk) |
---|
384 | | -{ |
---|
385 | | - int i; |
---|
386 | | - |
---|
387 | | - for (i = 0; i < tk->tp.nr_args; i++) |
---|
388 | | - traceprobe_free_probe_arg(&tk->tp.args[i]); |
---|
389 | | - |
---|
390 | | - kfree(tk->tp.call.class->system); |
---|
391 | | - kfree(tk->tp.call.name); |
---|
392 | | - kfree(tk->symbol); |
---|
393 | | - free_percpu(tk->nhit); |
---|
394 | | - kfree(tk); |
---|
395 | 303 | } |
---|
396 | 304 | |
---|
397 | 305 | static struct trace_kprobe *find_trace_kprobe(const char *event, |
---|
398 | 306 | const char *group) |
---|
399 | 307 | { |
---|
| 308 | + struct dyn_event *pos; |
---|
400 | 309 | struct trace_kprobe *tk; |
---|
401 | 310 | |
---|
402 | | - list_for_each_entry(tk, &probe_list, list) |
---|
403 | | - if (strcmp(trace_event_name(&tk->tp.call), event) == 0 && |
---|
404 | | - strcmp(tk->tp.call.class->system, group) == 0) |
---|
| 311 | + for_each_trace_kprobe(tk, pos) |
---|
| 312 | + if (strcmp(trace_probe_name(&tk->tp), event) == 0 && |
---|
| 313 | + strcmp(trace_probe_group_name(&tk->tp), group) == 0) |
---|
405 | 314 | return tk; |
---|
406 | 315 | return NULL; |
---|
407 | 316 | } |
---|
.. | .. |
---|
410 | 319 | { |
---|
411 | 320 | int ret = 0; |
---|
412 | 321 | |
---|
413 | | - if (trace_probe_is_registered(&tk->tp) && !trace_kprobe_has_gone(tk)) { |
---|
| 322 | + if (trace_kprobe_is_registered(tk) && !trace_kprobe_has_gone(tk)) { |
---|
414 | 323 | if (trace_kprobe_is_return(tk)) |
---|
415 | 324 | ret = enable_kretprobe(&tk->rp); |
---|
416 | 325 | else |
---|
.. | .. |
---|
420 | 329 | return ret; |
---|
421 | 330 | } |
---|
422 | 331 | |
---|
| 332 | +static void __disable_trace_kprobe(struct trace_probe *tp) |
---|
| 333 | +{ |
---|
| 334 | + struct trace_probe *pos; |
---|
| 335 | + struct trace_kprobe *tk; |
---|
| 336 | + |
---|
| 337 | + list_for_each_entry(pos, trace_probe_probe_list(tp), list) { |
---|
| 338 | + tk = container_of(pos, struct trace_kprobe, tp); |
---|
| 339 | + if (!trace_kprobe_is_registered(tk)) |
---|
| 340 | + continue; |
---|
| 341 | + if (trace_kprobe_is_return(tk)) |
---|
| 342 | + disable_kretprobe(&tk->rp); |
---|
| 343 | + else |
---|
| 344 | + disable_kprobe(&tk->rp.kp); |
---|
| 345 | + } |
---|
| 346 | +} |
---|
| 347 | + |
---|
423 | 348 | /* |
---|
424 | 349 | * Enable trace_probe |
---|
425 | 350 | * if the file is NULL, enable "perf" handler, or enable "trace" handler. |
---|
426 | 351 | */ |
---|
427 | | -static int |
---|
428 | | -enable_trace_kprobe(struct trace_kprobe *tk, struct trace_event_file *file) |
---|
| 352 | +static int enable_trace_kprobe(struct trace_event_call *call, |
---|
| 353 | + struct trace_event_file *file) |
---|
429 | 354 | { |
---|
430 | | - struct event_file_link *link; |
---|
| 355 | + struct trace_probe *pos, *tp; |
---|
| 356 | + struct trace_kprobe *tk; |
---|
| 357 | + bool enabled; |
---|
431 | 358 | int ret = 0; |
---|
432 | 359 | |
---|
| 360 | + tp = trace_probe_primary_from_call(call); |
---|
| 361 | + if (WARN_ON_ONCE(!tp)) |
---|
| 362 | + return -ENODEV; |
---|
| 363 | + enabled = trace_probe_is_enabled(tp); |
---|
| 364 | + |
---|
| 365 | + /* This also changes "enabled" state */ |
---|
433 | 366 | if (file) { |
---|
434 | | - link = kmalloc(sizeof(*link), GFP_KERNEL); |
---|
435 | | - if (!link) { |
---|
436 | | - ret = -ENOMEM; |
---|
437 | | - goto out; |
---|
438 | | - } |
---|
| 367 | + ret = trace_probe_add_file(tp, file); |
---|
| 368 | + if (ret) |
---|
| 369 | + return ret; |
---|
| 370 | + } else |
---|
| 371 | + trace_probe_set_flag(tp, TP_FLAG_PROFILE); |
---|
439 | 372 | |
---|
440 | | - link->file = file; |
---|
441 | | - list_add_tail_rcu(&link->list, &tk->tp.files); |
---|
| 373 | + if (enabled) |
---|
| 374 | + return 0; |
---|
442 | 375 | |
---|
443 | | - tk->tp.flags |= TP_FLAG_TRACE; |
---|
444 | | - ret = __enable_trace_kprobe(tk); |
---|
445 | | - if (ret) { |
---|
446 | | - list_del_rcu(&link->list); |
---|
447 | | - kfree(link); |
---|
448 | | - tk->tp.flags &= ~TP_FLAG_TRACE; |
---|
449 | | - } |
---|
450 | | - |
---|
451 | | - } else { |
---|
452 | | - tk->tp.flags |= TP_FLAG_PROFILE; |
---|
| 376 | + list_for_each_entry(pos, trace_probe_probe_list(tp), list) { |
---|
| 377 | + tk = container_of(pos, struct trace_kprobe, tp); |
---|
| 378 | + if (trace_kprobe_has_gone(tk)) |
---|
| 379 | + continue; |
---|
453 | 380 | ret = __enable_trace_kprobe(tk); |
---|
454 | 381 | if (ret) |
---|
455 | | - tk->tp.flags &= ~TP_FLAG_PROFILE; |
---|
| 382 | + break; |
---|
| 383 | + enabled = true; |
---|
456 | 384 | } |
---|
457 | | - out: |
---|
| 385 | + |
---|
| 386 | + if (ret) { |
---|
| 387 | + /* Failed to enable one of them. Roll back all */ |
---|
| 388 | + if (enabled) |
---|
| 389 | + __disable_trace_kprobe(tp); |
---|
| 390 | + if (file) |
---|
| 391 | + trace_probe_remove_file(tp, file); |
---|
| 392 | + else |
---|
| 393 | + trace_probe_clear_flag(tp, TP_FLAG_PROFILE); |
---|
| 394 | + } |
---|
| 395 | + |
---|
458 | 396 | return ret; |
---|
459 | 397 | } |
---|
460 | 398 | |
---|
.. | .. |
---|
462 | 400 | * Disable trace_probe |
---|
463 | 401 | * if the file is NULL, disable "perf" handler, or disable "trace" handler. |
---|
464 | 402 | */ |
---|
465 | | -static int |
---|
466 | | -disable_trace_kprobe(struct trace_kprobe *tk, struct trace_event_file *file) |
---|
| 403 | +static int disable_trace_kprobe(struct trace_event_call *call, |
---|
| 404 | + struct trace_event_file *file) |
---|
467 | 405 | { |
---|
468 | | - struct event_file_link *link = NULL; |
---|
469 | | - int wait = 0; |
---|
470 | | - int ret = 0; |
---|
| 406 | + struct trace_probe *tp; |
---|
| 407 | + |
---|
| 408 | + tp = trace_probe_primary_from_call(call); |
---|
| 409 | + if (WARN_ON_ONCE(!tp)) |
---|
| 410 | + return -ENODEV; |
---|
471 | 411 | |
---|
472 | 412 | if (file) { |
---|
473 | | - link = find_event_file_link(&tk->tp, file); |
---|
474 | | - if (!link) { |
---|
475 | | - ret = -EINVAL; |
---|
| 413 | + if (!trace_probe_get_file_link(tp, file)) |
---|
| 414 | + return -ENOENT; |
---|
| 415 | + if (!trace_probe_has_single_file(tp)) |
---|
476 | 416 | goto out; |
---|
477 | | - } |
---|
478 | | - |
---|
479 | | - list_del_rcu(&link->list); |
---|
480 | | - wait = 1; |
---|
481 | | - if (!list_empty(&tk->tp.files)) |
---|
482 | | - goto out; |
---|
483 | | - |
---|
484 | | - tk->tp.flags &= ~TP_FLAG_TRACE; |
---|
| 417 | + trace_probe_clear_flag(tp, TP_FLAG_TRACE); |
---|
485 | 418 | } else |
---|
486 | | - tk->tp.flags &= ~TP_FLAG_PROFILE; |
---|
| 419 | + trace_probe_clear_flag(tp, TP_FLAG_PROFILE); |
---|
487 | 420 | |
---|
488 | | - if (!trace_probe_is_enabled(&tk->tp) && trace_probe_is_registered(&tk->tp)) { |
---|
489 | | - if (trace_kprobe_is_return(tk)) |
---|
490 | | - disable_kretprobe(&tk->rp); |
---|
491 | | - else |
---|
492 | | - disable_kprobe(&tk->rp.kp); |
---|
493 | | - wait = 1; |
---|
494 | | - } |
---|
| 421 | + if (!trace_probe_is_enabled(tp)) |
---|
| 422 | + __disable_trace_kprobe(tp); |
---|
495 | 423 | |
---|
496 | | - /* |
---|
497 | | - * if tk is not added to any list, it must be a local trace_kprobe |
---|
498 | | - * created with perf_event_open. We don't need to wait for these |
---|
499 | | - * trace_kprobes |
---|
500 | | - */ |
---|
501 | | - if (list_empty(&tk->list)) |
---|
502 | | - wait = 0; |
---|
503 | 424 | out: |
---|
504 | | - if (wait) { |
---|
| 425 | + if (file) |
---|
505 | 426 | /* |
---|
506 | | - * Synchronize with kprobe_trace_func/kretprobe_trace_func |
---|
507 | | - * to ensure disabled (all running handlers are finished). |
---|
508 | | - * This is not only for kfree(), but also the caller, |
---|
509 | | - * trace_remove_event_call() supposes it for releasing |
---|
510 | | - * event_call related objects, which will be accessed in |
---|
511 | | - * the kprobe_trace_func/kretprobe_trace_func. |
---|
| 427 | + * Synchronization is done in below function. For perf event, |
---|
| 428 | + * file == NULL and perf_trace_event_unreg() calls |
---|
| 429 | + * tracepoint_synchronize_unregister() to ensure synchronize |
---|
| 430 | + * event. We don't need to care about it. |
---|
512 | 431 | */ |
---|
513 | | - synchronize_sched(); |
---|
514 | | - kfree(link); /* Ignored if link == NULL */ |
---|
515 | | - } |
---|
| 432 | + trace_probe_remove_file(tp, file); |
---|
516 | 433 | |
---|
517 | | - return ret; |
---|
| 434 | + return 0; |
---|
518 | 435 | } |
---|
519 | 436 | |
---|
520 | 437 | #if defined(CONFIG_DYNAMIC_FTRACE) && \ |
---|
.. | .. |
---|
566 | 483 | { |
---|
567 | 484 | int i, ret; |
---|
568 | 485 | |
---|
569 | | - if (trace_probe_is_registered(&tk->tp)) |
---|
| 486 | + ret = security_locked_down(LOCKDOWN_KPROBES); |
---|
| 487 | + if (ret) |
---|
| 488 | + return ret; |
---|
| 489 | + |
---|
| 490 | + if (trace_kprobe_is_registered(tk)) |
---|
570 | 491 | return -EINVAL; |
---|
571 | 492 | |
---|
572 | 493 | if (within_notrace_func(tk)) { |
---|
.. | .. |
---|
575 | 496 | return -EINVAL; |
---|
576 | 497 | } |
---|
577 | 498 | |
---|
578 | | - for (i = 0; i < tk->tp.nr_args; i++) |
---|
579 | | - traceprobe_update_arg(&tk->tp.args[i]); |
---|
| 499 | + for (i = 0; i < tk->tp.nr_args; i++) { |
---|
| 500 | + ret = traceprobe_update_arg(&tk->tp.args[i]); |
---|
| 501 | + if (ret) |
---|
| 502 | + return ret; |
---|
| 503 | + } |
---|
580 | 504 | |
---|
581 | 505 | /* Set/clear disabled flag according to tp->flag */ |
---|
582 | 506 | if (trace_probe_is_enabled(&tk->tp)) |
---|
.. | .. |
---|
589 | 513 | else |
---|
590 | 514 | ret = register_kprobe(&tk->rp.kp); |
---|
591 | 515 | |
---|
592 | | - if (ret == 0) { |
---|
593 | | - tk->tp.flags |= TP_FLAG_REGISTERED; |
---|
594 | | - } else if (ret == -EILSEQ) { |
---|
595 | | - pr_warn("Probing address(0x%p) is not an instruction boundary.\n", |
---|
596 | | - tk->rp.kp.addr); |
---|
597 | | - ret = -EINVAL; |
---|
598 | | - } |
---|
599 | 516 | return ret; |
---|
600 | 517 | } |
---|
601 | 518 | |
---|
602 | 519 | /* Internal unregister function - just handle k*probes and flags */ |
---|
603 | 520 | static void __unregister_trace_kprobe(struct trace_kprobe *tk) |
---|
604 | 521 | { |
---|
605 | | - if (trace_probe_is_registered(&tk->tp)) { |
---|
| 522 | + if (trace_kprobe_is_registered(tk)) { |
---|
606 | 523 | if (trace_kprobe_is_return(tk)) |
---|
607 | 524 | unregister_kretprobe(&tk->rp); |
---|
608 | 525 | else |
---|
609 | 526 | unregister_kprobe(&tk->rp.kp); |
---|
610 | | - tk->tp.flags &= ~TP_FLAG_REGISTERED; |
---|
611 | | - /* Cleanup kprobe for reuse */ |
---|
| 527 | + /* Cleanup kprobe for reuse and mark it unregistered */ |
---|
| 528 | + INIT_HLIST_NODE(&tk->rp.kp.hlist); |
---|
| 529 | + INIT_LIST_HEAD(&tk->rp.kp.list); |
---|
612 | 530 | if (tk->rp.kp.symbol_name) |
---|
613 | 531 | tk->rp.kp.addr = NULL; |
---|
614 | 532 | } |
---|
615 | 533 | } |
---|
616 | 534 | |
---|
617 | | -/* Unregister a trace_probe and probe_event: call with locking probe_lock */ |
---|
| 535 | +/* Unregister a trace_probe and probe_event */ |
---|
618 | 536 | static int unregister_trace_kprobe(struct trace_kprobe *tk) |
---|
619 | 537 | { |
---|
| 538 | + /* If other probes are on the event, just unregister kprobe */ |
---|
| 539 | + if (trace_probe_has_sibling(&tk->tp)) |
---|
| 540 | + goto unreg; |
---|
| 541 | + |
---|
620 | 542 | /* Enabled event can not be unregistered */ |
---|
621 | 543 | if (trace_probe_is_enabled(&tk->tp)) |
---|
622 | 544 | return -EBUSY; |
---|
.. | .. |
---|
625 | 547 | if (unregister_kprobe_event(tk)) |
---|
626 | 548 | return -EBUSY; |
---|
627 | 549 | |
---|
| 550 | +unreg: |
---|
628 | 551 | __unregister_trace_kprobe(tk); |
---|
629 | | - list_del(&tk->list); |
---|
| 552 | + dyn_event_remove(&tk->devent); |
---|
| 553 | + trace_probe_unlink(&tk->tp); |
---|
630 | 554 | |
---|
631 | 555 | return 0; |
---|
| 556 | +} |
---|
| 557 | + |
---|
| 558 | +static bool trace_kprobe_has_same_kprobe(struct trace_kprobe *orig, |
---|
| 559 | + struct trace_kprobe *comp) |
---|
| 560 | +{ |
---|
| 561 | + struct trace_probe_event *tpe = orig->tp.event; |
---|
| 562 | + struct trace_probe *pos; |
---|
| 563 | + int i; |
---|
| 564 | + |
---|
| 565 | + list_for_each_entry(pos, &tpe->probes, list) { |
---|
| 566 | + orig = container_of(pos, struct trace_kprobe, tp); |
---|
| 567 | + if (strcmp(trace_kprobe_symbol(orig), |
---|
| 568 | + trace_kprobe_symbol(comp)) || |
---|
| 569 | + trace_kprobe_offset(orig) != trace_kprobe_offset(comp)) |
---|
| 570 | + continue; |
---|
| 571 | + |
---|
| 572 | + /* |
---|
| 573 | + * trace_probe_compare_arg_type() ensured that nr_args and |
---|
| 574 | + * each argument name and type are same. Let's compare comm. |
---|
| 575 | + */ |
---|
| 576 | + for (i = 0; i < orig->tp.nr_args; i++) { |
---|
| 577 | + if (strcmp(orig->tp.args[i].comm, |
---|
| 578 | + comp->tp.args[i].comm)) |
---|
| 579 | + break; |
---|
| 580 | + } |
---|
| 581 | + |
---|
| 582 | + if (i == orig->tp.nr_args) |
---|
| 583 | + return true; |
---|
| 584 | + } |
---|
| 585 | + |
---|
| 586 | + return false; |
---|
| 587 | +} |
---|
| 588 | + |
---|
| 589 | +static int append_trace_kprobe(struct trace_kprobe *tk, struct trace_kprobe *to) |
---|
| 590 | +{ |
---|
| 591 | + int ret; |
---|
| 592 | + |
---|
| 593 | + ret = trace_probe_compare_arg_type(&tk->tp, &to->tp); |
---|
| 594 | + if (ret) { |
---|
| 595 | + /* Note that argument starts index = 2 */ |
---|
| 596 | + trace_probe_log_set_index(ret + 1); |
---|
| 597 | + trace_probe_log_err(0, DIFF_ARG_TYPE); |
---|
| 598 | + return -EEXIST; |
---|
| 599 | + } |
---|
| 600 | + if (trace_kprobe_has_same_kprobe(to, tk)) { |
---|
| 601 | + trace_probe_log_set_index(0); |
---|
| 602 | + trace_probe_log_err(0, SAME_PROBE); |
---|
| 603 | + return -EEXIST; |
---|
| 604 | + } |
---|
| 605 | + |
---|
| 606 | + /* Append to existing event */ |
---|
| 607 | + ret = trace_probe_append(&tk->tp, &to->tp); |
---|
| 608 | + if (ret) |
---|
| 609 | + return ret; |
---|
| 610 | + |
---|
| 611 | + /* Register k*probe */ |
---|
| 612 | + ret = __register_trace_kprobe(tk); |
---|
| 613 | + if (ret == -ENOENT && !trace_kprobe_module_exist(tk)) { |
---|
| 614 | + pr_warn("This probe might be able to register after target module is loaded. Continue.\n"); |
---|
| 615 | + ret = 0; |
---|
| 616 | + } |
---|
| 617 | + |
---|
| 618 | + if (ret) |
---|
| 619 | + trace_probe_unlink(&tk->tp); |
---|
| 620 | + else |
---|
| 621 | + dyn_event_add(&tk->devent); |
---|
| 622 | + |
---|
| 623 | + return ret; |
---|
632 | 624 | } |
---|
633 | 625 | |
---|
634 | 626 | /* Register a trace_probe and probe_event */ |
---|
.. | .. |
---|
637 | 629 | struct trace_kprobe *old_tk; |
---|
638 | 630 | int ret; |
---|
639 | 631 | |
---|
640 | | - mutex_lock(&probe_lock); |
---|
| 632 | + mutex_lock(&event_mutex); |
---|
641 | 633 | |
---|
642 | | - /* Delete old (same name) event if exist */ |
---|
643 | | - old_tk = find_trace_kprobe(trace_event_name(&tk->tp.call), |
---|
644 | | - tk->tp.call.class->system); |
---|
| 634 | + old_tk = find_trace_kprobe(trace_probe_name(&tk->tp), |
---|
| 635 | + trace_probe_group_name(&tk->tp)); |
---|
645 | 636 | if (old_tk) { |
---|
646 | | - ret = unregister_trace_kprobe(old_tk); |
---|
647 | | - if (ret < 0) |
---|
648 | | - goto end; |
---|
649 | | - free_trace_kprobe(old_tk); |
---|
| 637 | + if (trace_kprobe_is_return(tk) != trace_kprobe_is_return(old_tk)) { |
---|
| 638 | + trace_probe_log_set_index(0); |
---|
| 639 | + trace_probe_log_err(0, DIFF_PROBE_TYPE); |
---|
| 640 | + ret = -EEXIST; |
---|
| 641 | + } else { |
---|
| 642 | + ret = append_trace_kprobe(tk, old_tk); |
---|
| 643 | + } |
---|
| 644 | + goto end; |
---|
650 | 645 | } |
---|
651 | 646 | |
---|
652 | 647 | /* Register new event */ |
---|
653 | 648 | ret = register_kprobe_event(tk); |
---|
654 | 649 | if (ret) { |
---|
655 | | - pr_warn("Failed to register probe event(%d)\n", ret); |
---|
| 650 | + if (ret == -EEXIST) { |
---|
| 651 | + trace_probe_log_set_index(0); |
---|
| 652 | + trace_probe_log_err(0, EVENT_EXIST); |
---|
| 653 | + } else |
---|
| 654 | + pr_warn("Failed to register probe event(%d)\n", ret); |
---|
656 | 655 | goto end; |
---|
657 | 656 | } |
---|
658 | 657 | |
---|
.. | .. |
---|
666 | 665 | if (ret < 0) |
---|
667 | 666 | unregister_kprobe_event(tk); |
---|
668 | 667 | else |
---|
669 | | - list_add_tail(&tk->list, &probe_list); |
---|
| 668 | + dyn_event_add(&tk->devent); |
---|
670 | 669 | |
---|
671 | 670 | end: |
---|
672 | | - mutex_unlock(&probe_lock); |
---|
| 671 | + mutex_unlock(&event_mutex); |
---|
673 | 672 | return ret; |
---|
674 | 673 | } |
---|
675 | 674 | |
---|
.. | .. |
---|
678 | 677 | unsigned long val, void *data) |
---|
679 | 678 | { |
---|
680 | 679 | struct module *mod = data; |
---|
| 680 | + struct dyn_event *pos; |
---|
681 | 681 | struct trace_kprobe *tk; |
---|
682 | 682 | int ret; |
---|
683 | 683 | |
---|
.. | .. |
---|
685 | 685 | return NOTIFY_DONE; |
---|
686 | 686 | |
---|
687 | 687 | /* Update probes on coming module */ |
---|
688 | | - mutex_lock(&probe_lock); |
---|
689 | | - list_for_each_entry(tk, &probe_list, list) { |
---|
| 688 | + mutex_lock(&event_mutex); |
---|
| 689 | + for_each_trace_kprobe(tk, pos) { |
---|
690 | 690 | if (trace_kprobe_within_module(tk, mod)) { |
---|
691 | 691 | /* Don't need to check busy - this should have gone. */ |
---|
692 | 692 | __unregister_trace_kprobe(tk); |
---|
693 | 693 | ret = __register_trace_kprobe(tk); |
---|
694 | 694 | if (ret) |
---|
695 | 695 | pr_warn("Failed to re-register probe %s on %s: %d\n", |
---|
696 | | - trace_event_name(&tk->tp.call), |
---|
697 | | - mod->name, ret); |
---|
| 696 | + trace_probe_name(&tk->tp), |
---|
| 697 | + module_name(mod), ret); |
---|
698 | 698 | } |
---|
699 | 699 | } |
---|
700 | | - mutex_unlock(&probe_lock); |
---|
| 700 | + mutex_unlock(&event_mutex); |
---|
701 | 701 | |
---|
702 | 702 | return NOTIFY_DONE; |
---|
703 | 703 | } |
---|
.. | .. |
---|
715 | 715 | *name = '_'; |
---|
716 | 716 | } |
---|
717 | 717 | |
---|
718 | | -static int create_trace_kprobe(int argc, char **argv) |
---|
| 718 | +static int trace_kprobe_create(int argc, const char *argv[]) |
---|
719 | 719 | { |
---|
720 | 720 | /* |
---|
721 | 721 | * Argument syntax: |
---|
.. | .. |
---|
723 | 723 | * p[:[GRP/]EVENT] [MOD:]KSYM[+OFFS]|KADDR [FETCHARGS] |
---|
724 | 724 | * - Add kretprobe: |
---|
725 | 725 | * r[MAXACTIVE][:[GRP/]EVENT] [MOD:]KSYM[+0] [FETCHARGS] |
---|
| 726 | + * Or |
---|
| 727 | + * p:[GRP/]EVENT] [MOD:]KSYM[+0]%return [FETCHARGS] |
---|
| 728 | + * |
---|
726 | 729 | * Fetch args: |
---|
727 | 730 | * $retval : fetch return value |
---|
728 | 731 | * $stack : fetch stack address |
---|
.. | .. |
---|
738 | 741 | * Type of args: |
---|
739 | 742 | * FETCHARG:TYPE : use TYPE instead of unsigned long. |
---|
740 | 743 | */ |
---|
741 | | - struct trace_kprobe *tk; |
---|
742 | | - int i, ret = 0; |
---|
743 | | - bool is_return = false, is_delete = false; |
---|
744 | | - char *symbol = NULL, *event = NULL, *group = NULL; |
---|
| 744 | + struct trace_kprobe *tk = NULL; |
---|
| 745 | + int i, len, ret = 0; |
---|
| 746 | + bool is_return = false; |
---|
| 747 | + char *symbol = NULL, *tmp = NULL; |
---|
| 748 | + const char *event = NULL, *group = KPROBE_EVENT_SYSTEM; |
---|
745 | 749 | int maxactive = 0; |
---|
746 | | - char *arg; |
---|
747 | 750 | long offset = 0; |
---|
748 | 751 | void *addr = NULL; |
---|
749 | 752 | char buf[MAX_EVENT_NAME_LEN]; |
---|
| 753 | + unsigned int flags = TPARG_FL_KERNEL; |
---|
750 | 754 | |
---|
751 | | - /* argc must be >= 1 */ |
---|
752 | | - if (argv[0][0] == 'p') |
---|
753 | | - is_return = false; |
---|
754 | | - else if (argv[0][0] == 'r') |
---|
| 755 | + switch (argv[0][0]) { |
---|
| 756 | + case 'r': |
---|
755 | 757 | is_return = true; |
---|
756 | | - else if (argv[0][0] == '-') |
---|
757 | | - is_delete = true; |
---|
758 | | - else { |
---|
759 | | - pr_info("Probe definition must be started with 'p', 'r' or" |
---|
760 | | - " '-'.\n"); |
---|
761 | | - return -EINVAL; |
---|
| 758 | + break; |
---|
| 759 | + case 'p': |
---|
| 760 | + break; |
---|
| 761 | + default: |
---|
| 762 | + return -ECANCELED; |
---|
762 | 763 | } |
---|
| 764 | + if (argc < 2) |
---|
| 765 | + return -ECANCELED; |
---|
| 766 | + |
---|
| 767 | + trace_probe_log_init("trace_kprobe", argc, argv); |
---|
763 | 768 | |
---|
764 | 769 | event = strchr(&argv[0][1], ':'); |
---|
765 | | - if (event) { |
---|
766 | | - event[0] = '\0'; |
---|
| 770 | + if (event) |
---|
767 | 771 | event++; |
---|
768 | | - } |
---|
769 | | - if (is_return && isdigit(argv[0][1])) { |
---|
770 | | - ret = kstrtouint(&argv[0][1], 0, &maxactive); |
---|
771 | | - if (ret) { |
---|
772 | | - pr_info("Failed to parse maxactive.\n"); |
---|
773 | | - return ret; |
---|
| 772 | + |
---|
| 773 | + if (isdigit(argv[0][1])) { |
---|
| 774 | + if (!is_return) { |
---|
| 775 | + trace_probe_log_err(1, MAXACT_NO_KPROBE); |
---|
| 776 | + goto parse_error; |
---|
| 777 | + } |
---|
| 778 | + if (event) |
---|
| 779 | + len = event - &argv[0][1] - 1; |
---|
| 780 | + else |
---|
| 781 | + len = strlen(&argv[0][1]); |
---|
| 782 | + if (len > MAX_EVENT_NAME_LEN - 1) { |
---|
| 783 | + trace_probe_log_err(1, BAD_MAXACT); |
---|
| 784 | + goto parse_error; |
---|
| 785 | + } |
---|
| 786 | + memcpy(buf, &argv[0][1], len); |
---|
| 787 | + buf[len] = '\0'; |
---|
| 788 | + ret = kstrtouint(buf, 0, &maxactive); |
---|
| 789 | + if (ret || !maxactive) { |
---|
| 790 | + trace_probe_log_err(1, BAD_MAXACT); |
---|
| 791 | + goto parse_error; |
---|
774 | 792 | } |
---|
775 | 793 | /* kretprobes instances are iterated over via a list. The |
---|
776 | 794 | * maximum should stay reasonable. |
---|
777 | 795 | */ |
---|
778 | 796 | if (maxactive > KRETPROBE_MAXACTIVE_MAX) { |
---|
779 | | - pr_info("Maxactive is too big (%d > %d).\n", |
---|
780 | | - maxactive, KRETPROBE_MAXACTIVE_MAX); |
---|
781 | | - return -E2BIG; |
---|
| 797 | + trace_probe_log_err(1, MAXACT_TOO_BIG); |
---|
| 798 | + goto parse_error; |
---|
782 | 799 | } |
---|
783 | | - } |
---|
784 | | - |
---|
785 | | - if (event) { |
---|
786 | | - if (strchr(event, '/')) { |
---|
787 | | - group = event; |
---|
788 | | - event = strchr(group, '/') + 1; |
---|
789 | | - event[-1] = '\0'; |
---|
790 | | - if (strlen(group) == 0) { |
---|
791 | | - pr_info("Group name is not specified\n"); |
---|
792 | | - return -EINVAL; |
---|
793 | | - } |
---|
794 | | - } |
---|
795 | | - if (strlen(event) == 0) { |
---|
796 | | - pr_info("Event name is not specified\n"); |
---|
797 | | - return -EINVAL; |
---|
798 | | - } |
---|
799 | | - } |
---|
800 | | - if (!group) |
---|
801 | | - group = KPROBE_EVENT_SYSTEM; |
---|
802 | | - |
---|
803 | | - if (is_delete) { |
---|
804 | | - if (!event) { |
---|
805 | | - pr_info("Delete command needs an event name.\n"); |
---|
806 | | - return -EINVAL; |
---|
807 | | - } |
---|
808 | | - mutex_lock(&probe_lock); |
---|
809 | | - tk = find_trace_kprobe(event, group); |
---|
810 | | - if (!tk) { |
---|
811 | | - mutex_unlock(&probe_lock); |
---|
812 | | - pr_info("Event %s/%s doesn't exist.\n", group, event); |
---|
813 | | - return -ENOENT; |
---|
814 | | - } |
---|
815 | | - /* delete an event */ |
---|
816 | | - ret = unregister_trace_kprobe(tk); |
---|
817 | | - if (ret == 0) |
---|
818 | | - free_trace_kprobe(tk); |
---|
819 | | - mutex_unlock(&probe_lock); |
---|
820 | | - return ret; |
---|
821 | | - } |
---|
822 | | - |
---|
823 | | - if (argc < 2) { |
---|
824 | | - pr_info("Probe point is not specified.\n"); |
---|
825 | | - return -EINVAL; |
---|
826 | 800 | } |
---|
827 | 801 | |
---|
828 | 802 | /* try to parse an address. if that fails, try to read the |
---|
829 | 803 | * input as a symbol. */ |
---|
830 | 804 | if (kstrtoul(argv[1], 0, (unsigned long *)&addr)) { |
---|
| 805 | + trace_probe_log_set_index(1); |
---|
| 806 | + /* Check whether uprobe event specified */ |
---|
| 807 | + if (strchr(argv[1], '/') && strchr(argv[1], ':')) { |
---|
| 808 | + ret = -ECANCELED; |
---|
| 809 | + goto error; |
---|
| 810 | + } |
---|
831 | 811 | /* a symbol specified */ |
---|
832 | | - symbol = argv[1]; |
---|
| 812 | + symbol = kstrdup(argv[1], GFP_KERNEL); |
---|
| 813 | + if (!symbol) |
---|
| 814 | + return -ENOMEM; |
---|
| 815 | + |
---|
| 816 | + tmp = strchr(symbol, '%'); |
---|
| 817 | + if (tmp) { |
---|
| 818 | + if (!strcmp(tmp, "%return")) { |
---|
| 819 | + *tmp = '\0'; |
---|
| 820 | + is_return = true; |
---|
| 821 | + } else { |
---|
| 822 | + trace_probe_log_err(tmp - symbol, BAD_ADDR_SUFFIX); |
---|
| 823 | + goto parse_error; |
---|
| 824 | + } |
---|
| 825 | + } |
---|
| 826 | + |
---|
833 | 827 | /* TODO: support .init module functions */ |
---|
834 | 828 | ret = traceprobe_split_symbol_offset(symbol, &offset); |
---|
835 | 829 | if (ret || offset < 0 || offset > UINT_MAX) { |
---|
836 | | - pr_info("Failed to parse either an address or a symbol.\n"); |
---|
837 | | - return ret; |
---|
| 830 | + trace_probe_log_err(0, BAD_PROBE_ADDR); |
---|
| 831 | + goto parse_error; |
---|
838 | 832 | } |
---|
| 833 | + if (is_return) |
---|
| 834 | + flags |= TPARG_FL_RETURN; |
---|
| 835 | + ret = kprobe_on_func_entry(NULL, symbol, offset); |
---|
| 836 | + if (ret == 0) |
---|
| 837 | + flags |= TPARG_FL_FENTRY; |
---|
839 | 838 | /* Defer the ENOENT case until register kprobe */ |
---|
840 | | - if (offset && is_return && |
---|
841 | | - kprobe_on_func_entry(NULL, symbol, offset) == -EINVAL) { |
---|
842 | | - pr_info("Given offset is not valid for return probe.\n"); |
---|
843 | | - return -EINVAL; |
---|
| 839 | + if (ret == -EINVAL && is_return) { |
---|
| 840 | + trace_probe_log_err(0, BAD_RETPROBE); |
---|
| 841 | + goto parse_error; |
---|
844 | 842 | } |
---|
845 | 843 | } |
---|
846 | | - argc -= 2; argv += 2; |
---|
847 | 844 | |
---|
848 | | - /* setup a probe */ |
---|
849 | | - if (!event) { |
---|
| 845 | + trace_probe_log_set_index(0); |
---|
| 846 | + if (event) { |
---|
| 847 | + ret = traceprobe_parse_event_name(&event, &group, buf, |
---|
| 848 | + event - argv[0]); |
---|
| 849 | + if (ret) |
---|
| 850 | + goto parse_error; |
---|
| 851 | + } else { |
---|
850 | 852 | /* Make a new event name */ |
---|
851 | 853 | if (symbol) |
---|
852 | 854 | snprintf(buf, MAX_EVENT_NAME_LEN, "%c_%s_%ld", |
---|
.. | .. |
---|
857 | 859 | sanitize_event_name(buf); |
---|
858 | 860 | event = buf; |
---|
859 | 861 | } |
---|
| 862 | + |
---|
| 863 | + /* setup a probe */ |
---|
860 | 864 | tk = alloc_trace_kprobe(group, event, addr, symbol, offset, maxactive, |
---|
861 | | - argc, is_return); |
---|
| 865 | + argc - 2, is_return); |
---|
862 | 866 | if (IS_ERR(tk)) { |
---|
863 | | - pr_info("Failed to allocate trace_probe.(%d)\n", |
---|
864 | | - (int)PTR_ERR(tk)); |
---|
865 | | - return PTR_ERR(tk); |
---|
| 867 | + ret = PTR_ERR(tk); |
---|
| 868 | + /* This must return -ENOMEM, else there is a bug */ |
---|
| 869 | + WARN_ON_ONCE(ret != -ENOMEM); |
---|
| 870 | + goto out; /* We know tk is not allocated */ |
---|
866 | 871 | } |
---|
| 872 | + argc -= 2; argv += 2; |
---|
867 | 873 | |
---|
868 | 874 | /* parse arguments */ |
---|
869 | | - ret = 0; |
---|
870 | 875 | for (i = 0; i < argc && i < MAX_TRACE_ARGS; i++) { |
---|
871 | | - struct probe_arg *parg = &tk->tp.args[i]; |
---|
872 | | - |
---|
873 | | - /* Increment count for freeing args in error case */ |
---|
874 | | - tk->tp.nr_args++; |
---|
875 | | - |
---|
876 | | - /* Parse argument name */ |
---|
877 | | - arg = strchr(argv[i], '='); |
---|
878 | | - if (arg) { |
---|
879 | | - *arg++ = '\0'; |
---|
880 | | - parg->name = kstrdup(argv[i], GFP_KERNEL); |
---|
881 | | - } else { |
---|
882 | | - arg = argv[i]; |
---|
883 | | - /* If argument name is omitted, set "argN" */ |
---|
884 | | - snprintf(buf, MAX_EVENT_NAME_LEN, "arg%d", i + 1); |
---|
885 | | - parg->name = kstrdup(buf, GFP_KERNEL); |
---|
886 | | - } |
---|
887 | | - |
---|
888 | | - if (!parg->name) { |
---|
889 | | - pr_info("Failed to allocate argument[%d] name.\n", i); |
---|
| 876 | + tmp = kstrdup(argv[i], GFP_KERNEL); |
---|
| 877 | + if (!tmp) { |
---|
890 | 878 | ret = -ENOMEM; |
---|
891 | 879 | goto error; |
---|
892 | 880 | } |
---|
893 | 881 | |
---|
894 | | - if (!is_good_name(parg->name)) { |
---|
895 | | - pr_info("Invalid argument[%d] name: %s\n", |
---|
896 | | - i, parg->name); |
---|
897 | | - ret = -EINVAL; |
---|
898 | | - goto error; |
---|
899 | | - } |
---|
900 | | - |
---|
901 | | - if (traceprobe_conflict_field_name(parg->name, |
---|
902 | | - tk->tp.args, i)) { |
---|
903 | | - pr_info("Argument[%d] name '%s' conflicts with " |
---|
904 | | - "another field.\n", i, argv[i]); |
---|
905 | | - ret = -EINVAL; |
---|
906 | | - goto error; |
---|
907 | | - } |
---|
908 | | - |
---|
909 | | - /* Parse fetch argument */ |
---|
910 | | - ret = traceprobe_parse_probe_arg(arg, &tk->tp.size, parg, |
---|
911 | | - is_return, true, |
---|
912 | | - kprobes_fetch_type_table); |
---|
913 | | - if (ret) { |
---|
914 | | - pr_info("Parse error at argument[%d]. (%d)\n", i, ret); |
---|
915 | | - goto error; |
---|
916 | | - } |
---|
| 882 | + trace_probe_log_set_index(i + 2); |
---|
| 883 | + ret = traceprobe_parse_probe_arg(&tk->tp, i, tmp, flags); |
---|
| 884 | + kfree(tmp); |
---|
| 885 | + if (ret) |
---|
| 886 | + goto error; /* This can be -ENOMEM */ |
---|
917 | 887 | } |
---|
| 888 | + |
---|
| 889 | + ret = traceprobe_set_print_fmt(&tk->tp, is_return); |
---|
| 890 | + if (ret < 0) |
---|
| 891 | + goto error; |
---|
918 | 892 | |
---|
919 | 893 | ret = register_trace_kprobe(tk); |
---|
920 | | - if (ret) |
---|
| 894 | + if (ret) { |
---|
| 895 | + trace_probe_log_set_index(1); |
---|
| 896 | + if (ret == -EILSEQ) |
---|
| 897 | + trace_probe_log_err(0, BAD_INSN_BNDRY); |
---|
| 898 | + else if (ret == -ENOENT) |
---|
| 899 | + trace_probe_log_err(0, BAD_PROBE_ADDR); |
---|
| 900 | + else if (ret != -ENOMEM && ret != -EEXIST) |
---|
| 901 | + trace_probe_log_err(0, FAIL_REG_PROBE); |
---|
921 | 902 | goto error; |
---|
922 | | - return 0; |
---|
923 | | - |
---|
924 | | -error: |
---|
925 | | - free_trace_kprobe(tk); |
---|
926 | | - return ret; |
---|
927 | | -} |
---|
928 | | - |
---|
929 | | -static int release_all_trace_kprobes(void) |
---|
930 | | -{ |
---|
931 | | - struct trace_kprobe *tk; |
---|
932 | | - int ret = 0; |
---|
933 | | - |
---|
934 | | - mutex_lock(&probe_lock); |
---|
935 | | - /* Ensure no probe is in use. */ |
---|
936 | | - list_for_each_entry(tk, &probe_list, list) |
---|
937 | | - if (trace_probe_is_enabled(&tk->tp)) { |
---|
938 | | - ret = -EBUSY; |
---|
939 | | - goto end; |
---|
940 | | - } |
---|
941 | | - /* TODO: Use batch unregistration */ |
---|
942 | | - while (!list_empty(&probe_list)) { |
---|
943 | | - tk = list_entry(probe_list.next, struct trace_kprobe, list); |
---|
944 | | - ret = unregister_trace_kprobe(tk); |
---|
945 | | - if (ret) |
---|
946 | | - goto end; |
---|
947 | | - free_trace_kprobe(tk); |
---|
948 | 903 | } |
---|
949 | 904 | |
---|
950 | | -end: |
---|
951 | | - mutex_unlock(&probe_lock); |
---|
| 905 | +out: |
---|
| 906 | + trace_probe_log_clear(); |
---|
| 907 | + kfree(symbol); |
---|
| 908 | + return ret; |
---|
| 909 | + |
---|
| 910 | +parse_error: |
---|
| 911 | + ret = -EINVAL; |
---|
| 912 | +error: |
---|
| 913 | + free_trace_kprobe(tk); |
---|
| 914 | + goto out; |
---|
| 915 | +} |
---|
| 916 | + |
---|
| 917 | +static int create_or_delete_trace_kprobe(int argc, char **argv) |
---|
| 918 | +{ |
---|
| 919 | + int ret; |
---|
| 920 | + |
---|
| 921 | + if (argv[0][0] == '-') |
---|
| 922 | + return dyn_event_release(argc, argv, &trace_kprobe_ops); |
---|
| 923 | + |
---|
| 924 | + ret = trace_kprobe_create(argc, (const char **)argv); |
---|
| 925 | + return ret == -ECANCELED ? -EINVAL : ret; |
---|
| 926 | +} |
---|
| 927 | + |
---|
| 928 | +static int trace_kprobe_run_command(struct dynevent_cmd *cmd) |
---|
| 929 | +{ |
---|
| 930 | + return trace_run_command(cmd->seq.buffer, create_or_delete_trace_kprobe); |
---|
| 931 | +} |
---|
| 932 | + |
---|
| 933 | +/** |
---|
| 934 | + * kprobe_event_cmd_init - Initialize a kprobe event command object |
---|
| 935 | + * @cmd: A pointer to the dynevent_cmd struct representing the new event |
---|
| 936 | + * @buf: A pointer to the buffer used to build the command |
---|
| 937 | + * @maxlen: The length of the buffer passed in @buf |
---|
| 938 | + * |
---|
| 939 | + * Initialize a synthetic event command object. Use this before |
---|
| 940 | + * calling any of the other kprobe_event functions. |
---|
| 941 | + */ |
---|
| 942 | +void kprobe_event_cmd_init(struct dynevent_cmd *cmd, char *buf, int maxlen) |
---|
| 943 | +{ |
---|
| 944 | + dynevent_cmd_init(cmd, buf, maxlen, DYNEVENT_TYPE_KPROBE, |
---|
| 945 | + trace_kprobe_run_command); |
---|
| 946 | +} |
---|
| 947 | +EXPORT_SYMBOL_GPL(kprobe_event_cmd_init); |
---|
| 948 | + |
---|
| 949 | +/** |
---|
| 950 | + * __kprobe_event_gen_cmd_start - Generate a kprobe event command from arg list |
---|
| 951 | + * @cmd: A pointer to the dynevent_cmd struct representing the new event |
---|
| 952 | + * @name: The name of the kprobe event |
---|
| 953 | + * @loc: The location of the kprobe event |
---|
| 954 | + * @kretprobe: Is this a return probe? |
---|
| 955 | + * @args: Variable number of arg (pairs), one pair for each field |
---|
| 956 | + * |
---|
| 957 | + * NOTE: Users normally won't want to call this function directly, but |
---|
| 958 | + * rather use the kprobe_event_gen_cmd_start() wrapper, which automatically |
---|
| 959 | + * adds a NULL to the end of the arg list. If this function is used |
---|
| 960 | + * directly, make sure the last arg in the variable arg list is NULL. |
---|
| 961 | + * |
---|
| 962 | + * Generate a kprobe event command to be executed by |
---|
| 963 | + * kprobe_event_gen_cmd_end(). This function can be used to generate the |
---|
| 964 | + * complete command or only the first part of it; in the latter case, |
---|
| 965 | + * kprobe_event_add_fields() can be used to add more fields following this. |
---|
| 966 | + * |
---|
| 967 | + * Unlikely the synth_event_gen_cmd_start(), @loc must be specified. This |
---|
| 968 | + * returns -EINVAL if @loc == NULL. |
---|
| 969 | + * |
---|
| 970 | + * Return: 0 if successful, error otherwise. |
---|
| 971 | + */ |
---|
| 972 | +int __kprobe_event_gen_cmd_start(struct dynevent_cmd *cmd, bool kretprobe, |
---|
| 973 | + const char *name, const char *loc, ...) |
---|
| 974 | +{ |
---|
| 975 | + char buf[MAX_EVENT_NAME_LEN]; |
---|
| 976 | + struct dynevent_arg arg; |
---|
| 977 | + va_list args; |
---|
| 978 | + int ret; |
---|
| 979 | + |
---|
| 980 | + if (cmd->type != DYNEVENT_TYPE_KPROBE) |
---|
| 981 | + return -EINVAL; |
---|
| 982 | + |
---|
| 983 | + if (!loc) |
---|
| 984 | + return -EINVAL; |
---|
| 985 | + |
---|
| 986 | + if (kretprobe) |
---|
| 987 | + snprintf(buf, MAX_EVENT_NAME_LEN, "r:kprobes/%s", name); |
---|
| 988 | + else |
---|
| 989 | + snprintf(buf, MAX_EVENT_NAME_LEN, "p:kprobes/%s", name); |
---|
| 990 | + |
---|
| 991 | + ret = dynevent_str_add(cmd, buf); |
---|
| 992 | + if (ret) |
---|
| 993 | + return ret; |
---|
| 994 | + |
---|
| 995 | + dynevent_arg_init(&arg, 0); |
---|
| 996 | + arg.str = loc; |
---|
| 997 | + ret = dynevent_arg_add(cmd, &arg, NULL); |
---|
| 998 | + if (ret) |
---|
| 999 | + return ret; |
---|
| 1000 | + |
---|
| 1001 | + va_start(args, loc); |
---|
| 1002 | + for (;;) { |
---|
| 1003 | + const char *field; |
---|
| 1004 | + |
---|
| 1005 | + field = va_arg(args, const char *); |
---|
| 1006 | + if (!field) |
---|
| 1007 | + break; |
---|
| 1008 | + |
---|
| 1009 | + if (++cmd->n_fields > MAX_TRACE_ARGS) { |
---|
| 1010 | + ret = -EINVAL; |
---|
| 1011 | + break; |
---|
| 1012 | + } |
---|
| 1013 | + |
---|
| 1014 | + arg.str = field; |
---|
| 1015 | + ret = dynevent_arg_add(cmd, &arg, NULL); |
---|
| 1016 | + if (ret) |
---|
| 1017 | + break; |
---|
| 1018 | + } |
---|
| 1019 | + va_end(args); |
---|
952 | 1020 | |
---|
953 | 1021 | return ret; |
---|
954 | 1022 | } |
---|
| 1023 | +EXPORT_SYMBOL_GPL(__kprobe_event_gen_cmd_start); |
---|
955 | 1024 | |
---|
956 | | -/* Probes listing interfaces */ |
---|
957 | | -static void *probes_seq_start(struct seq_file *m, loff_t *pos) |
---|
| 1025 | +/** |
---|
| 1026 | + * __kprobe_event_add_fields - Add probe fields to a kprobe command from arg list |
---|
| 1027 | + * @cmd: A pointer to the dynevent_cmd struct representing the new event |
---|
| 1028 | + * @args: Variable number of arg (pairs), one pair for each field |
---|
| 1029 | + * |
---|
| 1030 | + * NOTE: Users normally won't want to call this function directly, but |
---|
| 1031 | + * rather use the kprobe_event_add_fields() wrapper, which |
---|
| 1032 | + * automatically adds a NULL to the end of the arg list. If this |
---|
| 1033 | + * function is used directly, make sure the last arg in the variable |
---|
| 1034 | + * arg list is NULL. |
---|
| 1035 | + * |
---|
| 1036 | + * Add probe fields to an existing kprobe command using a variable |
---|
| 1037 | + * list of args. Fields are added in the same order they're listed. |
---|
| 1038 | + * |
---|
| 1039 | + * Return: 0 if successful, error otherwise. |
---|
| 1040 | + */ |
---|
| 1041 | +int __kprobe_event_add_fields(struct dynevent_cmd *cmd, ...) |
---|
958 | 1042 | { |
---|
959 | | - mutex_lock(&probe_lock); |
---|
960 | | - return seq_list_start(&probe_list, *pos); |
---|
| 1043 | + struct dynevent_arg arg; |
---|
| 1044 | + va_list args; |
---|
| 1045 | + int ret = 0; |
---|
| 1046 | + |
---|
| 1047 | + if (cmd->type != DYNEVENT_TYPE_KPROBE) |
---|
| 1048 | + return -EINVAL; |
---|
| 1049 | + |
---|
| 1050 | + dynevent_arg_init(&arg, 0); |
---|
| 1051 | + |
---|
| 1052 | + va_start(args, cmd); |
---|
| 1053 | + for (;;) { |
---|
| 1054 | + const char *field; |
---|
| 1055 | + |
---|
| 1056 | + field = va_arg(args, const char *); |
---|
| 1057 | + if (!field) |
---|
| 1058 | + break; |
---|
| 1059 | + |
---|
| 1060 | + if (++cmd->n_fields > MAX_TRACE_ARGS) { |
---|
| 1061 | + ret = -EINVAL; |
---|
| 1062 | + break; |
---|
| 1063 | + } |
---|
| 1064 | + |
---|
| 1065 | + arg.str = field; |
---|
| 1066 | + ret = dynevent_arg_add(cmd, &arg, NULL); |
---|
| 1067 | + if (ret) |
---|
| 1068 | + break; |
---|
| 1069 | + } |
---|
| 1070 | + va_end(args); |
---|
| 1071 | + |
---|
| 1072 | + return ret; |
---|
| 1073 | +} |
---|
| 1074 | +EXPORT_SYMBOL_GPL(__kprobe_event_add_fields); |
---|
| 1075 | + |
---|
| 1076 | +/** |
---|
| 1077 | + * kprobe_event_delete - Delete a kprobe event |
---|
| 1078 | + * @name: The name of the kprobe event to delete |
---|
| 1079 | + * |
---|
| 1080 | + * Delete a kprobe event with the give @name from kernel code rather |
---|
| 1081 | + * than directly from the command line. |
---|
| 1082 | + * |
---|
| 1083 | + * Return: 0 if successful, error otherwise. |
---|
| 1084 | + */ |
---|
| 1085 | +int kprobe_event_delete(const char *name) |
---|
| 1086 | +{ |
---|
| 1087 | + char buf[MAX_EVENT_NAME_LEN]; |
---|
| 1088 | + |
---|
| 1089 | + snprintf(buf, MAX_EVENT_NAME_LEN, "-:%s", name); |
---|
| 1090 | + |
---|
| 1091 | + return trace_run_command(buf, create_or_delete_trace_kprobe); |
---|
| 1092 | +} |
---|
| 1093 | +EXPORT_SYMBOL_GPL(kprobe_event_delete); |
---|
| 1094 | + |
---|
| 1095 | +static int trace_kprobe_release(struct dyn_event *ev) |
---|
| 1096 | +{ |
---|
| 1097 | + struct trace_kprobe *tk = to_trace_kprobe(ev); |
---|
| 1098 | + int ret = unregister_trace_kprobe(tk); |
---|
| 1099 | + |
---|
| 1100 | + if (!ret) |
---|
| 1101 | + free_trace_kprobe(tk); |
---|
| 1102 | + return ret; |
---|
961 | 1103 | } |
---|
962 | 1104 | |
---|
963 | | -static void *probes_seq_next(struct seq_file *m, void *v, loff_t *pos) |
---|
| 1105 | +static int trace_kprobe_show(struct seq_file *m, struct dyn_event *ev) |
---|
964 | 1106 | { |
---|
965 | | - return seq_list_next(v, &probe_list, pos); |
---|
966 | | -} |
---|
967 | | - |
---|
968 | | -static void probes_seq_stop(struct seq_file *m, void *v) |
---|
969 | | -{ |
---|
970 | | - mutex_unlock(&probe_lock); |
---|
971 | | -} |
---|
972 | | - |
---|
973 | | -static int probes_seq_show(struct seq_file *m, void *v) |
---|
974 | | -{ |
---|
975 | | - struct trace_kprobe *tk = v; |
---|
| 1107 | + struct trace_kprobe *tk = to_trace_kprobe(ev); |
---|
976 | 1108 | int i; |
---|
977 | 1109 | |
---|
978 | 1110 | seq_putc(m, trace_kprobe_is_return(tk) ? 'r' : 'p'); |
---|
979 | 1111 | if (trace_kprobe_is_return(tk) && tk->rp.maxactive) |
---|
980 | 1112 | seq_printf(m, "%d", tk->rp.maxactive); |
---|
981 | | - seq_printf(m, ":%s/%s", tk->tp.call.class->system, |
---|
982 | | - trace_event_name(&tk->tp.call)); |
---|
| 1113 | + seq_printf(m, ":%s/%s", trace_probe_group_name(&tk->tp), |
---|
| 1114 | + trace_probe_name(&tk->tp)); |
---|
983 | 1115 | |
---|
984 | 1116 | if (!tk->symbol) |
---|
985 | 1117 | seq_printf(m, " 0x%p", tk->rp.kp.addr); |
---|
.. | .. |
---|
996 | 1128 | return 0; |
---|
997 | 1129 | } |
---|
998 | 1130 | |
---|
| 1131 | +static int probes_seq_show(struct seq_file *m, void *v) |
---|
| 1132 | +{ |
---|
| 1133 | + struct dyn_event *ev = v; |
---|
| 1134 | + |
---|
| 1135 | + if (!is_trace_kprobe(ev)) |
---|
| 1136 | + return 0; |
---|
| 1137 | + |
---|
| 1138 | + return trace_kprobe_show(m, ev); |
---|
| 1139 | +} |
---|
| 1140 | + |
---|
999 | 1141 | static const struct seq_operations probes_seq_op = { |
---|
1000 | | - .start = probes_seq_start, |
---|
1001 | | - .next = probes_seq_next, |
---|
1002 | | - .stop = probes_seq_stop, |
---|
| 1142 | + .start = dyn_event_seq_start, |
---|
| 1143 | + .next = dyn_event_seq_next, |
---|
| 1144 | + .stop = dyn_event_seq_stop, |
---|
1003 | 1145 | .show = probes_seq_show |
---|
1004 | 1146 | }; |
---|
1005 | 1147 | |
---|
.. | .. |
---|
1007 | 1149 | { |
---|
1008 | 1150 | int ret; |
---|
1009 | 1151 | |
---|
| 1152 | + ret = security_locked_down(LOCKDOWN_TRACEFS); |
---|
| 1153 | + if (ret) |
---|
| 1154 | + return ret; |
---|
| 1155 | + |
---|
1010 | 1156 | if ((file->f_mode & FMODE_WRITE) && (file->f_flags & O_TRUNC)) { |
---|
1011 | | - ret = release_all_trace_kprobes(); |
---|
| 1157 | + ret = dyn_events_release_all(&trace_kprobe_ops); |
---|
1012 | 1158 | if (ret < 0) |
---|
1013 | 1159 | return ret; |
---|
1014 | 1160 | } |
---|
.. | .. |
---|
1020 | 1166 | size_t count, loff_t *ppos) |
---|
1021 | 1167 | { |
---|
1022 | 1168 | return trace_parse_run_command(file, buffer, count, ppos, |
---|
1023 | | - create_trace_kprobe); |
---|
| 1169 | + create_or_delete_trace_kprobe); |
---|
1024 | 1170 | } |
---|
1025 | 1171 | |
---|
1026 | 1172 | static const struct file_operations kprobe_events_ops = { |
---|
.. | .. |
---|
1035 | 1181 | /* Probes profiling interfaces */ |
---|
1036 | 1182 | static int probes_profile_seq_show(struct seq_file *m, void *v) |
---|
1037 | 1183 | { |
---|
1038 | | - struct trace_kprobe *tk = v; |
---|
| 1184 | + struct dyn_event *ev = v; |
---|
| 1185 | + struct trace_kprobe *tk; |
---|
| 1186 | + unsigned long nmissed; |
---|
1039 | 1187 | |
---|
| 1188 | + if (!is_trace_kprobe(ev)) |
---|
| 1189 | + return 0; |
---|
| 1190 | + |
---|
| 1191 | + tk = to_trace_kprobe(ev); |
---|
| 1192 | + nmissed = trace_kprobe_is_return(tk) ? |
---|
| 1193 | + tk->rp.kp.nmissed + tk->rp.nmissed : tk->rp.kp.nmissed; |
---|
1040 | 1194 | seq_printf(m, " %-44s %15lu %15lu\n", |
---|
1041 | | - trace_event_name(&tk->tp.call), |
---|
| 1195 | + trace_probe_name(&tk->tp), |
---|
1042 | 1196 | trace_kprobe_nhit(tk), |
---|
1043 | | - tk->rp.kp.nmissed); |
---|
| 1197 | + nmissed); |
---|
1044 | 1198 | |
---|
1045 | 1199 | return 0; |
---|
1046 | 1200 | } |
---|
1047 | 1201 | |
---|
1048 | 1202 | static const struct seq_operations profile_seq_op = { |
---|
1049 | | - .start = probes_seq_start, |
---|
1050 | | - .next = probes_seq_next, |
---|
1051 | | - .stop = probes_seq_stop, |
---|
| 1203 | + .start = dyn_event_seq_start, |
---|
| 1204 | + .next = dyn_event_seq_next, |
---|
| 1205 | + .stop = dyn_event_seq_stop, |
---|
1052 | 1206 | .show = probes_profile_seq_show |
---|
1053 | 1207 | }; |
---|
1054 | 1208 | |
---|
1055 | 1209 | static int profile_open(struct inode *inode, struct file *file) |
---|
1056 | 1210 | { |
---|
| 1211 | + int ret; |
---|
| 1212 | + |
---|
| 1213 | + ret = security_locked_down(LOCKDOWN_TRACEFS); |
---|
| 1214 | + if (ret) |
---|
| 1215 | + return ret; |
---|
| 1216 | + |
---|
1057 | 1217 | return seq_open(file, &profile_seq_op); |
---|
1058 | 1218 | } |
---|
1059 | 1219 | |
---|
.. | .. |
---|
1065 | 1225 | .release = seq_release, |
---|
1066 | 1226 | }; |
---|
1067 | 1227 | |
---|
| 1228 | +/* Kprobe specific fetch functions */ |
---|
| 1229 | + |
---|
| 1230 | +/* Return the length of string -- including null terminal byte */ |
---|
| 1231 | +static nokprobe_inline int |
---|
| 1232 | +fetch_store_strlen_user(unsigned long addr) |
---|
| 1233 | +{ |
---|
| 1234 | + const void __user *uaddr = (__force const void __user *)addr; |
---|
| 1235 | + |
---|
| 1236 | + return strnlen_user_nofault(uaddr, MAX_STRING_SIZE); |
---|
| 1237 | +} |
---|
| 1238 | + |
---|
| 1239 | +/* Return the length of string -- including null terminal byte */ |
---|
| 1240 | +static nokprobe_inline int |
---|
| 1241 | +fetch_store_strlen(unsigned long addr) |
---|
| 1242 | +{ |
---|
| 1243 | + int ret, len = 0; |
---|
| 1244 | + u8 c; |
---|
| 1245 | + |
---|
| 1246 | +#ifdef CONFIG_ARCH_HAS_NON_OVERLAPPING_ADDRESS_SPACE |
---|
| 1247 | + if (addr < TASK_SIZE) |
---|
| 1248 | + return fetch_store_strlen_user(addr); |
---|
| 1249 | +#endif |
---|
| 1250 | + |
---|
| 1251 | + do { |
---|
| 1252 | + ret = copy_from_kernel_nofault(&c, (u8 *)addr + len, 1); |
---|
| 1253 | + len++; |
---|
| 1254 | + } while (c && ret == 0 && len < MAX_STRING_SIZE); |
---|
| 1255 | + |
---|
| 1256 | + return (ret < 0) ? ret : len; |
---|
| 1257 | +} |
---|
| 1258 | + |
---|
| 1259 | +/* |
---|
| 1260 | + * Fetch a null-terminated string from user. Caller MUST set *(u32 *)buf |
---|
| 1261 | + * with max length and relative data location. |
---|
| 1262 | + */ |
---|
| 1263 | +static nokprobe_inline int |
---|
| 1264 | +fetch_store_string_user(unsigned long addr, void *dest, void *base) |
---|
| 1265 | +{ |
---|
| 1266 | + const void __user *uaddr = (__force const void __user *)addr; |
---|
| 1267 | + int maxlen = get_loc_len(*(u32 *)dest); |
---|
| 1268 | + void *__dest; |
---|
| 1269 | + long ret; |
---|
| 1270 | + |
---|
| 1271 | + if (unlikely(!maxlen)) |
---|
| 1272 | + return -ENOMEM; |
---|
| 1273 | + |
---|
| 1274 | + __dest = get_loc_data(dest, base); |
---|
| 1275 | + |
---|
| 1276 | + ret = strncpy_from_user_nofault(__dest, uaddr, maxlen); |
---|
| 1277 | + if (ret >= 0) |
---|
| 1278 | + *(u32 *)dest = make_data_loc(ret, __dest - base); |
---|
| 1279 | + |
---|
| 1280 | + return ret; |
---|
| 1281 | +} |
---|
| 1282 | + |
---|
| 1283 | +/* |
---|
| 1284 | + * Fetch a null-terminated string. Caller MUST set *(u32 *)buf with max |
---|
| 1285 | + * length and relative data location. |
---|
| 1286 | + */ |
---|
| 1287 | +static nokprobe_inline int |
---|
| 1288 | +fetch_store_string(unsigned long addr, void *dest, void *base) |
---|
| 1289 | +{ |
---|
| 1290 | + int maxlen = get_loc_len(*(u32 *)dest); |
---|
| 1291 | + void *__dest; |
---|
| 1292 | + long ret; |
---|
| 1293 | + |
---|
| 1294 | +#ifdef CONFIG_ARCH_HAS_NON_OVERLAPPING_ADDRESS_SPACE |
---|
| 1295 | + if ((unsigned long)addr < TASK_SIZE) |
---|
| 1296 | + return fetch_store_string_user(addr, dest, base); |
---|
| 1297 | +#endif |
---|
| 1298 | + |
---|
| 1299 | + if (unlikely(!maxlen)) |
---|
| 1300 | + return -ENOMEM; |
---|
| 1301 | + |
---|
| 1302 | + __dest = get_loc_data(dest, base); |
---|
| 1303 | + |
---|
| 1304 | + /* |
---|
| 1305 | + * Try to get string again, since the string can be changed while |
---|
| 1306 | + * probing. |
---|
| 1307 | + */ |
---|
| 1308 | + ret = strncpy_from_kernel_nofault(__dest, (void *)addr, maxlen); |
---|
| 1309 | + if (ret >= 0) |
---|
| 1310 | + *(u32 *)dest = make_data_loc(ret, __dest - base); |
---|
| 1311 | + |
---|
| 1312 | + return ret; |
---|
| 1313 | +} |
---|
| 1314 | + |
---|
| 1315 | +static nokprobe_inline int |
---|
| 1316 | +probe_mem_read_user(void *dest, void *src, size_t size) |
---|
| 1317 | +{ |
---|
| 1318 | + const void __user *uaddr = (__force const void __user *)src; |
---|
| 1319 | + |
---|
| 1320 | + return copy_from_user_nofault(dest, uaddr, size); |
---|
| 1321 | +} |
---|
| 1322 | + |
---|
| 1323 | +static nokprobe_inline int |
---|
| 1324 | +probe_mem_read(void *dest, void *src, size_t size) |
---|
| 1325 | +{ |
---|
| 1326 | +#ifdef CONFIG_ARCH_HAS_NON_OVERLAPPING_ADDRESS_SPACE |
---|
| 1327 | + if ((unsigned long)src < TASK_SIZE) |
---|
| 1328 | + return probe_mem_read_user(dest, src, size); |
---|
| 1329 | +#endif |
---|
| 1330 | + return copy_from_kernel_nofault(dest, src, size); |
---|
| 1331 | +} |
---|
| 1332 | + |
---|
| 1333 | +/* Note that we don't verify it, since the code does not come from user space */ |
---|
| 1334 | +static int |
---|
| 1335 | +process_fetch_insn(struct fetch_insn *code, void *rec, void *dest, |
---|
| 1336 | + void *base) |
---|
| 1337 | +{ |
---|
| 1338 | + struct pt_regs *regs = rec; |
---|
| 1339 | + unsigned long val; |
---|
| 1340 | + |
---|
| 1341 | +retry: |
---|
| 1342 | + /* 1st stage: get value from context */ |
---|
| 1343 | + switch (code->op) { |
---|
| 1344 | + case FETCH_OP_REG: |
---|
| 1345 | + val = regs_get_register(regs, code->param); |
---|
| 1346 | + break; |
---|
| 1347 | + case FETCH_OP_STACK: |
---|
| 1348 | + val = regs_get_kernel_stack_nth(regs, code->param); |
---|
| 1349 | + break; |
---|
| 1350 | + case FETCH_OP_STACKP: |
---|
| 1351 | + val = kernel_stack_pointer(regs); |
---|
| 1352 | + break; |
---|
| 1353 | + case FETCH_OP_RETVAL: |
---|
| 1354 | + val = regs_return_value(regs); |
---|
| 1355 | + break; |
---|
| 1356 | + case FETCH_OP_IMM: |
---|
| 1357 | + val = code->immediate; |
---|
| 1358 | + break; |
---|
| 1359 | + case FETCH_OP_COMM: |
---|
| 1360 | + val = (unsigned long)current->comm; |
---|
| 1361 | + break; |
---|
| 1362 | + case FETCH_OP_DATA: |
---|
| 1363 | + val = (unsigned long)code->data; |
---|
| 1364 | + break; |
---|
| 1365 | +#ifdef CONFIG_HAVE_FUNCTION_ARG_ACCESS_API |
---|
| 1366 | + case FETCH_OP_ARG: |
---|
| 1367 | + val = regs_get_kernel_argument(regs, code->param); |
---|
| 1368 | + break; |
---|
| 1369 | +#endif |
---|
| 1370 | + case FETCH_NOP_SYMBOL: /* Ignore a place holder */ |
---|
| 1371 | + code++; |
---|
| 1372 | + goto retry; |
---|
| 1373 | + default: |
---|
| 1374 | + return -EILSEQ; |
---|
| 1375 | + } |
---|
| 1376 | + code++; |
---|
| 1377 | + |
---|
| 1378 | + return process_fetch_insn_bottom(code, val, dest, base); |
---|
| 1379 | +} |
---|
| 1380 | +NOKPROBE_SYMBOL(process_fetch_insn) |
---|
| 1381 | + |
---|
1068 | 1382 | /* Kprobe handler */ |
---|
1069 | 1383 | static nokprobe_inline void |
---|
1070 | 1384 | __kprobe_trace_func(struct trace_kprobe *tk, struct pt_regs *regs, |
---|
1071 | 1385 | struct trace_event_file *trace_file) |
---|
1072 | 1386 | { |
---|
1073 | 1387 | struct kprobe_trace_entry_head *entry; |
---|
1074 | | - struct ring_buffer_event *event; |
---|
1075 | | - struct ring_buffer *buffer; |
---|
1076 | | - int size, dsize, pc; |
---|
1077 | | - unsigned long irq_flags; |
---|
1078 | | - struct trace_event_call *call = &tk->tp.call; |
---|
| 1388 | + struct trace_event_call *call = trace_probe_event_call(&tk->tp); |
---|
| 1389 | + struct trace_event_buffer fbuffer; |
---|
| 1390 | + int dsize; |
---|
1079 | 1391 | |
---|
1080 | 1392 | WARN_ON(call != trace_file->event_call); |
---|
1081 | 1393 | |
---|
1082 | 1394 | if (trace_trigger_soft_disabled(trace_file)) |
---|
1083 | 1395 | return; |
---|
1084 | 1396 | |
---|
1085 | | - local_save_flags(irq_flags); |
---|
1086 | | - pc = preempt_count(); |
---|
| 1397 | + local_save_flags(fbuffer.flags); |
---|
| 1398 | + fbuffer.pc = preempt_count(); |
---|
| 1399 | + fbuffer.trace_file = trace_file; |
---|
1087 | 1400 | |
---|
1088 | 1401 | dsize = __get_data_size(&tk->tp, regs); |
---|
1089 | | - size = sizeof(*entry) + tk->tp.size + dsize; |
---|
1090 | 1402 | |
---|
1091 | | - event = trace_event_buffer_lock_reserve(&buffer, trace_file, |
---|
1092 | | - call->event.type, |
---|
1093 | | - size, irq_flags, pc); |
---|
1094 | | - if (!event) |
---|
| 1403 | + fbuffer.event = |
---|
| 1404 | + trace_event_buffer_lock_reserve(&fbuffer.buffer, trace_file, |
---|
| 1405 | + call->event.type, |
---|
| 1406 | + sizeof(*entry) + tk->tp.size + dsize, |
---|
| 1407 | + fbuffer.flags, fbuffer.pc); |
---|
| 1408 | + if (!fbuffer.event) |
---|
1095 | 1409 | return; |
---|
1096 | 1410 | |
---|
1097 | | - entry = ring_buffer_event_data(event); |
---|
| 1411 | + fbuffer.regs = regs; |
---|
| 1412 | + entry = fbuffer.entry = ring_buffer_event_data(fbuffer.event); |
---|
1098 | 1413 | entry->ip = (unsigned long)tk->rp.kp.addr; |
---|
1099 | | - store_trace_args(sizeof(*entry), &tk->tp, regs, (u8 *)&entry[1], dsize); |
---|
| 1414 | + store_trace_args(&entry[1], &tk->tp, regs, sizeof(*entry), dsize); |
---|
1100 | 1415 | |
---|
1101 | | - event_trigger_unlock_commit_regs(trace_file, buffer, event, |
---|
1102 | | - entry, irq_flags, pc, regs); |
---|
| 1416 | + trace_event_buffer_commit(&fbuffer); |
---|
1103 | 1417 | } |
---|
1104 | 1418 | |
---|
1105 | 1419 | static void |
---|
.. | .. |
---|
1107 | 1421 | { |
---|
1108 | 1422 | struct event_file_link *link; |
---|
1109 | 1423 | |
---|
1110 | | - list_for_each_entry_rcu(link, &tk->tp.files, list) |
---|
| 1424 | + trace_probe_for_each_link_rcu(link, &tk->tp) |
---|
1111 | 1425 | __kprobe_trace_func(tk, regs, link->file); |
---|
1112 | 1426 | } |
---|
1113 | 1427 | NOKPROBE_SYMBOL(kprobe_trace_func); |
---|
.. | .. |
---|
1119 | 1433 | struct trace_event_file *trace_file) |
---|
1120 | 1434 | { |
---|
1121 | 1435 | struct kretprobe_trace_entry_head *entry; |
---|
1122 | | - struct ring_buffer_event *event; |
---|
1123 | | - struct ring_buffer *buffer; |
---|
1124 | | - int size, pc, dsize; |
---|
1125 | | - unsigned long irq_flags; |
---|
1126 | | - struct trace_event_call *call = &tk->tp.call; |
---|
| 1436 | + struct trace_event_buffer fbuffer; |
---|
| 1437 | + struct trace_event_call *call = trace_probe_event_call(&tk->tp); |
---|
| 1438 | + int dsize; |
---|
1127 | 1439 | |
---|
1128 | 1440 | WARN_ON(call != trace_file->event_call); |
---|
1129 | 1441 | |
---|
1130 | 1442 | if (trace_trigger_soft_disabled(trace_file)) |
---|
1131 | 1443 | return; |
---|
1132 | 1444 | |
---|
1133 | | - local_save_flags(irq_flags); |
---|
1134 | | - pc = preempt_count(); |
---|
| 1445 | + local_save_flags(fbuffer.flags); |
---|
| 1446 | + fbuffer.pc = preempt_count(); |
---|
| 1447 | + fbuffer.trace_file = trace_file; |
---|
1135 | 1448 | |
---|
1136 | 1449 | dsize = __get_data_size(&tk->tp, regs); |
---|
1137 | | - size = sizeof(*entry) + tk->tp.size + dsize; |
---|
1138 | | - |
---|
1139 | | - event = trace_event_buffer_lock_reserve(&buffer, trace_file, |
---|
1140 | | - call->event.type, |
---|
1141 | | - size, irq_flags, pc); |
---|
1142 | | - if (!event) |
---|
| 1450 | + fbuffer.event = |
---|
| 1451 | + trace_event_buffer_lock_reserve(&fbuffer.buffer, trace_file, |
---|
| 1452 | + call->event.type, |
---|
| 1453 | + sizeof(*entry) + tk->tp.size + dsize, |
---|
| 1454 | + fbuffer.flags, fbuffer.pc); |
---|
| 1455 | + if (!fbuffer.event) |
---|
1143 | 1456 | return; |
---|
1144 | 1457 | |
---|
1145 | | - entry = ring_buffer_event_data(event); |
---|
| 1458 | + fbuffer.regs = regs; |
---|
| 1459 | + entry = fbuffer.entry = ring_buffer_event_data(fbuffer.event); |
---|
1146 | 1460 | entry->func = (unsigned long)tk->rp.kp.addr; |
---|
1147 | 1461 | entry->ret_ip = (unsigned long)ri->ret_addr; |
---|
1148 | | - store_trace_args(sizeof(*entry), &tk->tp, regs, (u8 *)&entry[1], dsize); |
---|
| 1462 | + store_trace_args(&entry[1], &tk->tp, regs, sizeof(*entry), dsize); |
---|
1149 | 1463 | |
---|
1150 | | - event_trigger_unlock_commit_regs(trace_file, buffer, event, |
---|
1151 | | - entry, irq_flags, pc, regs); |
---|
| 1464 | + trace_event_buffer_commit(&fbuffer); |
---|
1152 | 1465 | } |
---|
1153 | 1466 | |
---|
1154 | 1467 | static void |
---|
.. | .. |
---|
1157 | 1470 | { |
---|
1158 | 1471 | struct event_file_link *link; |
---|
1159 | 1472 | |
---|
1160 | | - list_for_each_entry_rcu(link, &tk->tp.files, list) |
---|
| 1473 | + trace_probe_for_each_link_rcu(link, &tk->tp) |
---|
1161 | 1474 | __kretprobe_trace_func(tk, ri, regs, link->file); |
---|
1162 | 1475 | } |
---|
1163 | 1476 | NOKPROBE_SYMBOL(kretprobe_trace_func); |
---|
.. | .. |
---|
1170 | 1483 | struct kprobe_trace_entry_head *field; |
---|
1171 | 1484 | struct trace_seq *s = &iter->seq; |
---|
1172 | 1485 | struct trace_probe *tp; |
---|
1173 | | - u8 *data; |
---|
1174 | | - int i; |
---|
1175 | 1486 | |
---|
1176 | 1487 | field = (struct kprobe_trace_entry_head *)iter->ent; |
---|
1177 | | - tp = container_of(event, struct trace_probe, call.event); |
---|
| 1488 | + tp = trace_probe_primary_from_call( |
---|
| 1489 | + container_of(event, struct trace_event_call, event)); |
---|
| 1490 | + if (WARN_ON_ONCE(!tp)) |
---|
| 1491 | + goto out; |
---|
1178 | 1492 | |
---|
1179 | | - trace_seq_printf(s, "%s: (", trace_event_name(&tp->call)); |
---|
| 1493 | + trace_seq_printf(s, "%s: (", trace_probe_name(tp)); |
---|
1180 | 1494 | |
---|
1181 | 1495 | if (!seq_print_ip_sym(s, field->ip, flags | TRACE_ITER_SYM_OFFSET)) |
---|
1182 | 1496 | goto out; |
---|
1183 | 1497 | |
---|
1184 | 1498 | trace_seq_putc(s, ')'); |
---|
1185 | 1499 | |
---|
1186 | | - data = (u8 *)&field[1]; |
---|
1187 | | - for (i = 0; i < tp->nr_args; i++) |
---|
1188 | | - if (!tp->args[i].type->print(s, tp->args[i].name, |
---|
1189 | | - data + tp->args[i].offset, field)) |
---|
1190 | | - goto out; |
---|
| 1500 | + if (print_probe_args(s, tp->args, tp->nr_args, |
---|
| 1501 | + (u8 *)&field[1], field) < 0) |
---|
| 1502 | + goto out; |
---|
1191 | 1503 | |
---|
1192 | 1504 | trace_seq_putc(s, '\n'); |
---|
1193 | 1505 | out: |
---|
.. | .. |
---|
1201 | 1513 | struct kretprobe_trace_entry_head *field; |
---|
1202 | 1514 | struct trace_seq *s = &iter->seq; |
---|
1203 | 1515 | struct trace_probe *tp; |
---|
1204 | | - u8 *data; |
---|
1205 | | - int i; |
---|
1206 | 1516 | |
---|
1207 | 1517 | field = (struct kretprobe_trace_entry_head *)iter->ent; |
---|
1208 | | - tp = container_of(event, struct trace_probe, call.event); |
---|
| 1518 | + tp = trace_probe_primary_from_call( |
---|
| 1519 | + container_of(event, struct trace_event_call, event)); |
---|
| 1520 | + if (WARN_ON_ONCE(!tp)) |
---|
| 1521 | + goto out; |
---|
1209 | 1522 | |
---|
1210 | | - trace_seq_printf(s, "%s: (", trace_event_name(&tp->call)); |
---|
| 1523 | + trace_seq_printf(s, "%s: (", trace_probe_name(tp)); |
---|
1211 | 1524 | |
---|
1212 | 1525 | if (!seq_print_ip_sym(s, field->ret_ip, flags | TRACE_ITER_SYM_OFFSET)) |
---|
1213 | 1526 | goto out; |
---|
.. | .. |
---|
1219 | 1532 | |
---|
1220 | 1533 | trace_seq_putc(s, ')'); |
---|
1221 | 1534 | |
---|
1222 | | - data = (u8 *)&field[1]; |
---|
1223 | | - for (i = 0; i < tp->nr_args; i++) |
---|
1224 | | - if (!tp->args[i].type->print(s, tp->args[i].name, |
---|
1225 | | - data + tp->args[i].offset, field)) |
---|
1226 | | - goto out; |
---|
| 1535 | + if (print_probe_args(s, tp->args, tp->nr_args, |
---|
| 1536 | + (u8 *)&field[1], field) < 0) |
---|
| 1537 | + goto out; |
---|
1227 | 1538 | |
---|
1228 | 1539 | trace_seq_putc(s, '\n'); |
---|
1229 | 1540 | |
---|
.. | .. |
---|
1234 | 1545 | |
---|
1235 | 1546 | static int kprobe_event_define_fields(struct trace_event_call *event_call) |
---|
1236 | 1547 | { |
---|
1237 | | - int ret, i; |
---|
| 1548 | + int ret; |
---|
1238 | 1549 | struct kprobe_trace_entry_head field; |
---|
1239 | | - struct trace_kprobe *tk = (struct trace_kprobe *)event_call->data; |
---|
| 1550 | + struct trace_probe *tp; |
---|
| 1551 | + |
---|
| 1552 | + tp = trace_probe_primary_from_call(event_call); |
---|
| 1553 | + if (WARN_ON_ONCE(!tp)) |
---|
| 1554 | + return -ENOENT; |
---|
1240 | 1555 | |
---|
1241 | 1556 | DEFINE_FIELD(unsigned long, ip, FIELD_STRING_IP, 0); |
---|
1242 | | - /* Set argument names as fields */ |
---|
1243 | | - for (i = 0; i < tk->tp.nr_args; i++) { |
---|
1244 | | - struct probe_arg *parg = &tk->tp.args[i]; |
---|
1245 | 1557 | |
---|
1246 | | - ret = trace_define_field(event_call, parg->type->fmttype, |
---|
1247 | | - parg->name, |
---|
1248 | | - sizeof(field) + parg->offset, |
---|
1249 | | - parg->type->size, |
---|
1250 | | - parg->type->is_signed, |
---|
1251 | | - FILTER_OTHER); |
---|
1252 | | - if (ret) |
---|
1253 | | - return ret; |
---|
1254 | | - } |
---|
1255 | | - return 0; |
---|
| 1558 | + return traceprobe_define_arg_fields(event_call, sizeof(field), tp); |
---|
1256 | 1559 | } |
---|
1257 | 1560 | |
---|
1258 | 1561 | static int kretprobe_event_define_fields(struct trace_event_call *event_call) |
---|
1259 | 1562 | { |
---|
1260 | | - int ret, i; |
---|
| 1563 | + int ret; |
---|
1261 | 1564 | struct kretprobe_trace_entry_head field; |
---|
1262 | | - struct trace_kprobe *tk = (struct trace_kprobe *)event_call->data; |
---|
| 1565 | + struct trace_probe *tp; |
---|
| 1566 | + |
---|
| 1567 | + tp = trace_probe_primary_from_call(event_call); |
---|
| 1568 | + if (WARN_ON_ONCE(!tp)) |
---|
| 1569 | + return -ENOENT; |
---|
1263 | 1570 | |
---|
1264 | 1571 | DEFINE_FIELD(unsigned long, func, FIELD_STRING_FUNC, 0); |
---|
1265 | 1572 | DEFINE_FIELD(unsigned long, ret_ip, FIELD_STRING_RETIP, 0); |
---|
1266 | | - /* Set argument names as fields */ |
---|
1267 | | - for (i = 0; i < tk->tp.nr_args; i++) { |
---|
1268 | | - struct probe_arg *parg = &tk->tp.args[i]; |
---|
1269 | 1573 | |
---|
1270 | | - ret = trace_define_field(event_call, parg->type->fmttype, |
---|
1271 | | - parg->name, |
---|
1272 | | - sizeof(field) + parg->offset, |
---|
1273 | | - parg->type->size, |
---|
1274 | | - parg->type->is_signed, |
---|
1275 | | - FILTER_OTHER); |
---|
1276 | | - if (ret) |
---|
1277 | | - return ret; |
---|
1278 | | - } |
---|
1279 | | - return 0; |
---|
| 1574 | + return traceprobe_define_arg_fields(event_call, sizeof(field), tp); |
---|
1280 | 1575 | } |
---|
1281 | 1576 | |
---|
1282 | 1577 | #ifdef CONFIG_PERF_EVENTS |
---|
.. | .. |
---|
1285 | 1580 | static int |
---|
1286 | 1581 | kprobe_perf_func(struct trace_kprobe *tk, struct pt_regs *regs) |
---|
1287 | 1582 | { |
---|
1288 | | - struct trace_event_call *call = &tk->tp.call; |
---|
| 1583 | + struct trace_event_call *call = trace_probe_event_call(&tk->tp); |
---|
1289 | 1584 | struct kprobe_trace_entry_head *entry; |
---|
1290 | 1585 | struct hlist_head *head; |
---|
1291 | 1586 | int size, __size, dsize; |
---|
.. | .. |
---|
1323 | 1618 | |
---|
1324 | 1619 | entry->ip = (unsigned long)tk->rp.kp.addr; |
---|
1325 | 1620 | memset(&entry[1], 0, dsize); |
---|
1326 | | - store_trace_args(sizeof(*entry), &tk->tp, regs, (u8 *)&entry[1], dsize); |
---|
| 1621 | + store_trace_args(&entry[1], &tk->tp, regs, sizeof(*entry), dsize); |
---|
1327 | 1622 | perf_trace_buf_submit(entry, size, rctx, call->event.type, 1, regs, |
---|
1328 | 1623 | head, NULL); |
---|
1329 | 1624 | return 0; |
---|
.. | .. |
---|
1335 | 1630 | kretprobe_perf_func(struct trace_kprobe *tk, struct kretprobe_instance *ri, |
---|
1336 | 1631 | struct pt_regs *regs) |
---|
1337 | 1632 | { |
---|
1338 | | - struct trace_event_call *call = &tk->tp.call; |
---|
| 1633 | + struct trace_event_call *call = trace_probe_event_call(&tk->tp); |
---|
1339 | 1634 | struct kretprobe_trace_entry_head *entry; |
---|
1340 | 1635 | struct hlist_head *head; |
---|
1341 | 1636 | int size, __size, dsize; |
---|
.. | .. |
---|
1359 | 1654 | |
---|
1360 | 1655 | entry->func = (unsigned long)tk->rp.kp.addr; |
---|
1361 | 1656 | entry->ret_ip = (unsigned long)ri->ret_addr; |
---|
1362 | | - store_trace_args(sizeof(*entry), &tk->tp, regs, (u8 *)&entry[1], dsize); |
---|
| 1657 | + store_trace_args(&entry[1], &tk->tp, regs, sizeof(*entry), dsize); |
---|
1363 | 1658 | perf_trace_buf_submit(entry, size, rctx, call->event.type, 1, regs, |
---|
1364 | 1659 | head, NULL); |
---|
1365 | 1660 | } |
---|
.. | .. |
---|
1376 | 1671 | if (perf_type_tracepoint) |
---|
1377 | 1672 | tk = find_trace_kprobe(pevent, group); |
---|
1378 | 1673 | else |
---|
1379 | | - tk = event->tp_event->data; |
---|
| 1674 | + tk = trace_kprobe_primary_from_call(event->tp_event); |
---|
1380 | 1675 | if (!tk) |
---|
1381 | 1676 | return -EINVAL; |
---|
1382 | 1677 | |
---|
.. | .. |
---|
1404 | 1699 | static int kprobe_register(struct trace_event_call *event, |
---|
1405 | 1700 | enum trace_reg type, void *data) |
---|
1406 | 1701 | { |
---|
1407 | | - struct trace_kprobe *tk = (struct trace_kprobe *)event->data; |
---|
1408 | 1702 | struct trace_event_file *file = data; |
---|
1409 | 1703 | |
---|
1410 | 1704 | switch (type) { |
---|
1411 | 1705 | case TRACE_REG_REGISTER: |
---|
1412 | | - return enable_trace_kprobe(tk, file); |
---|
| 1706 | + return enable_trace_kprobe(event, file); |
---|
1413 | 1707 | case TRACE_REG_UNREGISTER: |
---|
1414 | | - return disable_trace_kprobe(tk, file); |
---|
| 1708 | + return disable_trace_kprobe(event, file); |
---|
1415 | 1709 | |
---|
1416 | 1710 | #ifdef CONFIG_PERF_EVENTS |
---|
1417 | 1711 | case TRACE_REG_PERF_REGISTER: |
---|
1418 | | - return enable_trace_kprobe(tk, NULL); |
---|
| 1712 | + return enable_trace_kprobe(event, NULL); |
---|
1419 | 1713 | case TRACE_REG_PERF_UNREGISTER: |
---|
1420 | | - return disable_trace_kprobe(tk, NULL); |
---|
| 1714 | + return disable_trace_kprobe(event, NULL); |
---|
1421 | 1715 | case TRACE_REG_PERF_OPEN: |
---|
1422 | 1716 | case TRACE_REG_PERF_CLOSE: |
---|
1423 | 1717 | case TRACE_REG_PERF_ADD: |
---|
.. | .. |
---|
1435 | 1729 | |
---|
1436 | 1730 | raw_cpu_inc(*tk->nhit); |
---|
1437 | 1731 | |
---|
1438 | | - if (tk->tp.flags & TP_FLAG_TRACE) |
---|
| 1732 | + if (trace_probe_test_flag(&tk->tp, TP_FLAG_TRACE)) |
---|
1439 | 1733 | kprobe_trace_func(tk, regs); |
---|
1440 | 1734 | #ifdef CONFIG_PERF_EVENTS |
---|
1441 | | - if (tk->tp.flags & TP_FLAG_PROFILE) |
---|
| 1735 | + if (trace_probe_test_flag(&tk->tp, TP_FLAG_PROFILE)) |
---|
1442 | 1736 | ret = kprobe_perf_func(tk, regs); |
---|
1443 | 1737 | #endif |
---|
1444 | 1738 | return ret; |
---|
.. | .. |
---|
1452 | 1746 | |
---|
1453 | 1747 | raw_cpu_inc(*tk->nhit); |
---|
1454 | 1748 | |
---|
1455 | | - if (tk->tp.flags & TP_FLAG_TRACE) |
---|
| 1749 | + if (trace_probe_test_flag(&tk->tp, TP_FLAG_TRACE)) |
---|
1456 | 1750 | kretprobe_trace_func(tk, ri, regs); |
---|
1457 | 1751 | #ifdef CONFIG_PERF_EVENTS |
---|
1458 | | - if (tk->tp.flags & TP_FLAG_PROFILE) |
---|
| 1752 | + if (trace_probe_test_flag(&tk->tp, TP_FLAG_PROFILE)) |
---|
1459 | 1753 | kretprobe_perf_func(tk, ri, regs); |
---|
1460 | 1754 | #endif |
---|
1461 | 1755 | return 0; /* We don't tweek kernel, so just return 0 */ |
---|
.. | .. |
---|
1470 | 1764 | .trace = print_kprobe_event |
---|
1471 | 1765 | }; |
---|
1472 | 1766 | |
---|
1473 | | -static inline void init_trace_event_call(struct trace_kprobe *tk, |
---|
1474 | | - struct trace_event_call *call) |
---|
| 1767 | +static struct trace_event_fields kretprobe_fields_array[] = { |
---|
| 1768 | + { .type = TRACE_FUNCTION_TYPE, |
---|
| 1769 | + .define_fields = kretprobe_event_define_fields }, |
---|
| 1770 | + {} |
---|
| 1771 | +}; |
---|
| 1772 | + |
---|
| 1773 | +static struct trace_event_fields kprobe_fields_array[] = { |
---|
| 1774 | + { .type = TRACE_FUNCTION_TYPE, |
---|
| 1775 | + .define_fields = kprobe_event_define_fields }, |
---|
| 1776 | + {} |
---|
| 1777 | +}; |
---|
| 1778 | + |
---|
| 1779 | +static inline void init_trace_event_call(struct trace_kprobe *tk) |
---|
1475 | 1780 | { |
---|
1476 | | - INIT_LIST_HEAD(&call->class->fields); |
---|
| 1781 | + struct trace_event_call *call = trace_probe_event_call(&tk->tp); |
---|
| 1782 | + |
---|
1477 | 1783 | if (trace_kprobe_is_return(tk)) { |
---|
1478 | 1784 | call->event.funcs = &kretprobe_funcs; |
---|
1479 | | - call->class->define_fields = kretprobe_event_define_fields; |
---|
| 1785 | + call->class->fields_array = kretprobe_fields_array; |
---|
1480 | 1786 | } else { |
---|
1481 | 1787 | call->event.funcs = &kprobe_funcs; |
---|
1482 | | - call->class->define_fields = kprobe_event_define_fields; |
---|
| 1788 | + call->class->fields_array = kprobe_fields_array; |
---|
1483 | 1789 | } |
---|
1484 | 1790 | |
---|
1485 | 1791 | call->flags = TRACE_EVENT_FL_KPROBE; |
---|
1486 | 1792 | call->class->reg = kprobe_register; |
---|
1487 | | - call->data = tk; |
---|
1488 | 1793 | } |
---|
1489 | 1794 | |
---|
1490 | 1795 | static int register_kprobe_event(struct trace_kprobe *tk) |
---|
1491 | 1796 | { |
---|
1492 | | - struct trace_event_call *call = &tk->tp.call; |
---|
1493 | | - int ret = 0; |
---|
| 1797 | + init_trace_event_call(tk); |
---|
1494 | 1798 | |
---|
1495 | | - init_trace_event_call(tk, call); |
---|
1496 | | - |
---|
1497 | | - if (set_print_fmt(&tk->tp, trace_kprobe_is_return(tk)) < 0) |
---|
1498 | | - return -ENOMEM; |
---|
1499 | | - ret = register_trace_event(&call->event); |
---|
1500 | | - if (!ret) { |
---|
1501 | | - kfree(call->print_fmt); |
---|
1502 | | - return -ENODEV; |
---|
1503 | | - } |
---|
1504 | | - ret = trace_add_event_call(call); |
---|
1505 | | - if (ret) { |
---|
1506 | | - pr_info("Failed to register kprobe event: %s\n", |
---|
1507 | | - trace_event_name(call)); |
---|
1508 | | - kfree(call->print_fmt); |
---|
1509 | | - unregister_trace_event(&call->event); |
---|
1510 | | - } |
---|
1511 | | - return ret; |
---|
| 1799 | + return trace_probe_register_event_call(&tk->tp); |
---|
1512 | 1800 | } |
---|
1513 | 1801 | |
---|
1514 | 1802 | static int unregister_kprobe_event(struct trace_kprobe *tk) |
---|
1515 | 1803 | { |
---|
1516 | | - int ret; |
---|
1517 | | - |
---|
1518 | | - /* tp->event is unregistered in trace_remove_event_call() */ |
---|
1519 | | - ret = trace_remove_event_call(&tk->tp.call); |
---|
1520 | | - if (!ret) |
---|
1521 | | - kfree(tk->tp.call.print_fmt); |
---|
1522 | | - return ret; |
---|
| 1804 | + return trace_probe_unregister_event_call(&tk->tp); |
---|
1523 | 1805 | } |
---|
1524 | 1806 | |
---|
1525 | 1807 | #ifdef CONFIG_PERF_EVENTS |
---|
.. | .. |
---|
1533 | 1815 | char *event; |
---|
1534 | 1816 | |
---|
1535 | 1817 | /* |
---|
1536 | | - * local trace_kprobes are not added to probe_list, so they are never |
---|
| 1818 | + * local trace_kprobes are not added to dyn_event, so they are never |
---|
1537 | 1819 | * searched in find_trace_kprobe(). Therefore, there is no concern of |
---|
1538 | 1820 | * duplicated name here. |
---|
1539 | 1821 | */ |
---|
.. | .. |
---|
1549 | 1831 | return ERR_CAST(tk); |
---|
1550 | 1832 | } |
---|
1551 | 1833 | |
---|
1552 | | - init_trace_event_call(tk, &tk->tp.call); |
---|
| 1834 | + init_trace_event_call(tk); |
---|
1553 | 1835 | |
---|
1554 | | - if (set_print_fmt(&tk->tp, trace_kprobe_is_return(tk)) < 0) { |
---|
| 1836 | + if (traceprobe_set_print_fmt(&tk->tp, trace_kprobe_is_return(tk)) < 0) { |
---|
1555 | 1837 | ret = -ENOMEM; |
---|
1556 | 1838 | goto error; |
---|
1557 | 1839 | } |
---|
1558 | 1840 | |
---|
1559 | 1841 | ret = __register_trace_kprobe(tk); |
---|
1560 | | - if (ret < 0) { |
---|
1561 | | - kfree(tk->tp.call.print_fmt); |
---|
| 1842 | + if (ret < 0) |
---|
1562 | 1843 | goto error; |
---|
1563 | | - } |
---|
1564 | 1844 | |
---|
1565 | | - return &tk->tp.call; |
---|
| 1845 | + return trace_probe_event_call(&tk->tp); |
---|
1566 | 1846 | error: |
---|
1567 | 1847 | free_trace_kprobe(tk); |
---|
1568 | 1848 | return ERR_PTR(ret); |
---|
.. | .. |
---|
1572 | 1852 | { |
---|
1573 | 1853 | struct trace_kprobe *tk; |
---|
1574 | 1854 | |
---|
1575 | | - tk = container_of(event_call, struct trace_kprobe, tp.call); |
---|
| 1855 | + tk = trace_kprobe_primary_from_call(event_call); |
---|
| 1856 | + if (unlikely(!tk)) |
---|
| 1857 | + return; |
---|
1576 | 1858 | |
---|
1577 | 1859 | if (trace_probe_is_enabled(&tk->tp)) { |
---|
1578 | 1860 | WARN_ON(1); |
---|
.. | .. |
---|
1581 | 1863 | |
---|
1582 | 1864 | __unregister_trace_kprobe(tk); |
---|
1583 | 1865 | |
---|
1584 | | - kfree(tk->tp.call.print_fmt); |
---|
1585 | 1866 | free_trace_kprobe(tk); |
---|
1586 | 1867 | } |
---|
1587 | 1868 | #endif /* CONFIG_PERF_EVENTS */ |
---|
1588 | 1869 | |
---|
1589 | | -/* Make a tracefs interface for controlling probe points */ |
---|
1590 | | -static __init int init_kprobe_trace(void) |
---|
| 1870 | +static __init void enable_boot_kprobe_events(void) |
---|
1591 | 1871 | { |
---|
1592 | | - struct dentry *d_tracer; |
---|
1593 | | - struct dentry *entry; |
---|
| 1872 | + struct trace_array *tr = top_trace_array(); |
---|
| 1873 | + struct trace_event_file *file; |
---|
| 1874 | + struct trace_kprobe *tk; |
---|
| 1875 | + struct dyn_event *pos; |
---|
| 1876 | + |
---|
| 1877 | + mutex_lock(&event_mutex); |
---|
| 1878 | + for_each_trace_kprobe(tk, pos) { |
---|
| 1879 | + list_for_each_entry(file, &tr->events, list) |
---|
| 1880 | + if (file->event_call == trace_probe_event_call(&tk->tp)) |
---|
| 1881 | + trace_event_enable_disable(file, 1, 0); |
---|
| 1882 | + } |
---|
| 1883 | + mutex_unlock(&event_mutex); |
---|
| 1884 | +} |
---|
| 1885 | + |
---|
| 1886 | +static __init void setup_boot_kprobe_events(void) |
---|
| 1887 | +{ |
---|
| 1888 | + char *p, *cmd = kprobe_boot_events_buf; |
---|
| 1889 | + int ret; |
---|
| 1890 | + |
---|
| 1891 | + strreplace(kprobe_boot_events_buf, ',', ' '); |
---|
| 1892 | + |
---|
| 1893 | + while (cmd && *cmd != '\0') { |
---|
| 1894 | + p = strchr(cmd, ';'); |
---|
| 1895 | + if (p) |
---|
| 1896 | + *p++ = '\0'; |
---|
| 1897 | + |
---|
| 1898 | + ret = trace_run_command(cmd, create_or_delete_trace_kprobe); |
---|
| 1899 | + if (ret) |
---|
| 1900 | + pr_warn("Failed to add event(%d): %s\n", ret, cmd); |
---|
| 1901 | + |
---|
| 1902 | + cmd = p; |
---|
| 1903 | + } |
---|
| 1904 | + |
---|
| 1905 | + enable_boot_kprobe_events(); |
---|
| 1906 | +} |
---|
| 1907 | + |
---|
| 1908 | +/* |
---|
| 1909 | + * Register dynevent at core_initcall. This allows kernel to setup kprobe |
---|
| 1910 | + * events in postcore_initcall without tracefs. |
---|
| 1911 | + */ |
---|
| 1912 | +static __init int init_kprobe_trace_early(void) |
---|
| 1913 | +{ |
---|
| 1914 | + int ret; |
---|
| 1915 | + |
---|
| 1916 | + ret = dyn_event_register(&trace_kprobe_ops); |
---|
| 1917 | + if (ret) |
---|
| 1918 | + return ret; |
---|
1594 | 1919 | |
---|
1595 | 1920 | if (register_module_notifier(&trace_kprobe_module_nb)) |
---|
1596 | 1921 | return -EINVAL; |
---|
1597 | 1922 | |
---|
1598 | | - d_tracer = tracing_init_dentry(); |
---|
1599 | | - if (IS_ERR(d_tracer)) |
---|
| 1923 | + return 0; |
---|
| 1924 | +} |
---|
| 1925 | +core_initcall(init_kprobe_trace_early); |
---|
| 1926 | + |
---|
| 1927 | +/* Make a tracefs interface for controlling probe points */ |
---|
| 1928 | +static __init int init_kprobe_trace(void) |
---|
| 1929 | +{ |
---|
| 1930 | + int ret; |
---|
| 1931 | + struct dentry *entry; |
---|
| 1932 | + |
---|
| 1933 | + ret = tracing_init_dentry(); |
---|
| 1934 | + if (ret) |
---|
1600 | 1935 | return 0; |
---|
1601 | 1936 | |
---|
1602 | | - entry = tracefs_create_file("kprobe_events", 0644, d_tracer, |
---|
| 1937 | + entry = tracefs_create_file("kprobe_events", 0644, NULL, |
---|
1603 | 1938 | NULL, &kprobe_events_ops); |
---|
1604 | 1939 | |
---|
1605 | 1940 | /* Event list interface */ |
---|
.. | .. |
---|
1607 | 1942 | pr_warn("Could not create tracefs 'kprobe_events' entry\n"); |
---|
1608 | 1943 | |
---|
1609 | 1944 | /* Profile interface */ |
---|
1610 | | - entry = tracefs_create_file("kprobe_profile", 0444, d_tracer, |
---|
| 1945 | + entry = tracefs_create_file("kprobe_profile", 0444, NULL, |
---|
1611 | 1946 | NULL, &kprobe_profile_ops); |
---|
1612 | 1947 | |
---|
1613 | 1948 | if (!entry) |
---|
1614 | 1949 | pr_warn("Could not create tracefs 'kprobe_profile' entry\n"); |
---|
| 1950 | + |
---|
| 1951 | + setup_boot_kprobe_events(); |
---|
| 1952 | + |
---|
1615 | 1953 | return 0; |
---|
1616 | 1954 | } |
---|
1617 | 1955 | fs_initcall(init_kprobe_trace); |
---|
.. | .. |
---|
1624 | 1962 | struct trace_event_file *file; |
---|
1625 | 1963 | |
---|
1626 | 1964 | list_for_each_entry(file, &tr->events, list) |
---|
1627 | | - if (file->event_call == &tk->tp.call) |
---|
| 1965 | + if (file->event_call == trace_probe_event_call(&tk->tp)) |
---|
1628 | 1966 | return file; |
---|
1629 | 1967 | |
---|
1630 | 1968 | return NULL; |
---|
.. | .. |
---|
1644 | 1982 | if (tracing_is_disabled()) |
---|
1645 | 1983 | return -ENODEV; |
---|
1646 | 1984 | |
---|
| 1985 | + if (tracing_selftest_disabled) |
---|
| 1986 | + return 0; |
---|
| 1987 | + |
---|
1647 | 1988 | target = kprobe_trace_selftest_target; |
---|
1648 | 1989 | |
---|
1649 | 1990 | pr_info("Testing kprobe tracing: "); |
---|
1650 | 1991 | |
---|
1651 | | - ret = trace_run_command("p:testprobe kprobe_trace_selftest_target " |
---|
1652 | | - "$stack $stack0 +0($stack)", |
---|
1653 | | - create_trace_kprobe); |
---|
| 1992 | + ret = trace_run_command("p:testprobe kprobe_trace_selftest_target $stack $stack0 +0($stack)", |
---|
| 1993 | + create_or_delete_trace_kprobe); |
---|
1654 | 1994 | if (WARN_ON_ONCE(ret)) { |
---|
1655 | 1995 | pr_warn("error on probing function entry.\n"); |
---|
1656 | 1996 | warn++; |
---|
.. | .. |
---|
1666 | 2006 | pr_warn("error on getting probe file.\n"); |
---|
1667 | 2007 | warn++; |
---|
1668 | 2008 | } else |
---|
1669 | | - enable_trace_kprobe(tk, file); |
---|
| 2009 | + enable_trace_kprobe( |
---|
| 2010 | + trace_probe_event_call(&tk->tp), file); |
---|
1670 | 2011 | } |
---|
1671 | 2012 | } |
---|
1672 | 2013 | |
---|
1673 | | - ret = trace_run_command("r:testprobe2 kprobe_trace_selftest_target " |
---|
1674 | | - "$retval", create_trace_kprobe); |
---|
| 2014 | + ret = trace_run_command("r:testprobe2 kprobe_trace_selftest_target $retval", |
---|
| 2015 | + create_or_delete_trace_kprobe); |
---|
1675 | 2016 | if (WARN_ON_ONCE(ret)) { |
---|
1676 | 2017 | pr_warn("error on probing function return.\n"); |
---|
1677 | 2018 | warn++; |
---|
.. | .. |
---|
1687 | 2028 | pr_warn("error on getting probe file.\n"); |
---|
1688 | 2029 | warn++; |
---|
1689 | 2030 | } else |
---|
1690 | | - enable_trace_kprobe(tk, file); |
---|
| 2031 | + enable_trace_kprobe( |
---|
| 2032 | + trace_probe_event_call(&tk->tp), file); |
---|
1691 | 2033 | } |
---|
1692 | 2034 | } |
---|
1693 | 2035 | |
---|
.. | .. |
---|
1720 | 2062 | pr_warn("error on getting probe file.\n"); |
---|
1721 | 2063 | warn++; |
---|
1722 | 2064 | } else |
---|
1723 | | - disable_trace_kprobe(tk, file); |
---|
| 2065 | + disable_trace_kprobe( |
---|
| 2066 | + trace_probe_event_call(&tk->tp), file); |
---|
1724 | 2067 | } |
---|
1725 | 2068 | |
---|
1726 | 2069 | tk = find_trace_kprobe("testprobe2", KPROBE_EVENT_SYSTEM); |
---|
.. | .. |
---|
1738 | 2081 | pr_warn("error on getting probe file.\n"); |
---|
1739 | 2082 | warn++; |
---|
1740 | 2083 | } else |
---|
1741 | | - disable_trace_kprobe(tk, file); |
---|
| 2084 | + disable_trace_kprobe( |
---|
| 2085 | + trace_probe_event_call(&tk->tp), file); |
---|
1742 | 2086 | } |
---|
1743 | 2087 | |
---|
1744 | | - ret = trace_run_command("-:testprobe", create_trace_kprobe); |
---|
| 2088 | + ret = trace_run_command("-:testprobe", create_or_delete_trace_kprobe); |
---|
1745 | 2089 | if (WARN_ON_ONCE(ret)) { |
---|
1746 | 2090 | pr_warn("error on deleting a probe.\n"); |
---|
1747 | 2091 | warn++; |
---|
1748 | 2092 | } |
---|
1749 | 2093 | |
---|
1750 | | - ret = trace_run_command("-:testprobe2", create_trace_kprobe); |
---|
| 2094 | + ret = trace_run_command("-:testprobe2", create_or_delete_trace_kprobe); |
---|
1751 | 2095 | if (WARN_ON_ONCE(ret)) { |
---|
1752 | 2096 | pr_warn("error on deleting a probe.\n"); |
---|
1753 | 2097 | warn++; |
---|
1754 | 2098 | } |
---|
1755 | 2099 | |
---|
1756 | 2100 | end: |
---|
1757 | | - release_all_trace_kprobes(); |
---|
| 2101 | + ret = dyn_events_release_all(&trace_kprobe_ops); |
---|
| 2102 | + if (WARN_ON_ONCE(ret)) { |
---|
| 2103 | + pr_warn("error on cleaning up probes.\n"); |
---|
| 2104 | + warn++; |
---|
| 2105 | + } |
---|
1758 | 2106 | /* |
---|
1759 | 2107 | * Wait for the optimizer work to finish. Otherwise it might fiddle |
---|
1760 | 2108 | * with probes in already freed __init text. |
---|