Linux Perf
trace-event-python.c
Go to the documentation of this file.
1 /*
2  * trace-event-python. Feed trace events to an embedded Python interpreter.
3  *
4  * Copyright (C) 2010 Tom Zanussi <tzanussi@gmail.com>
5  *
6  * This program is free software; you can redistribute it and/or modify
7  * it under the terms of the GNU General Public License as published by
8  * the Free Software Foundation; either version 2 of the License, or
9  * (at your option) any later version.
10  *
11  * This program is distributed in the hope that it will be useful,
12  * but WITHOUT ANY WARRANTY; without even the implied warranty of
13  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14  * GNU General Public License for more details.
15  *
16  * You should have received a copy of the GNU General Public License
17  * along with this program; if not, write to the Free Software
18  * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
19  *
20  */
21 
22 #include <Python.h>
23 
24 #include <inttypes.h>
25 #include <stdio.h>
26 #include <stdlib.h>
27 #include <string.h>
28 #include <stdbool.h>
29 #include <errno.h>
30 #include <linux/bitmap.h>
31 #include <linux/compiler.h>
32 #include <linux/time64.h>
33 
34 #include "../../perf.h"
35 #include "../debug.h"
36 #include "../callchain.h"
37 #include "../evsel.h"
38 #include "../util.h"
39 #include "../event.h"
40 #include "../thread.h"
41 #include "../comm.h"
42 #include "../machine.h"
43 #include "../db-export.h"
44 #include "../thread-stack.h"
45 #include "../trace-event.h"
46 #include "../call-path.h"
47 #include "thread_map.h"
48 #include "cpumap.h"
49 #include "print_binary.h"
50 #include "stat.h"
51 #include "mem-events.h"
52 
53 #if PY_MAJOR_VERSION < 3
54 #define _PyUnicode_FromString(arg) \
55  PyString_FromString(arg)
56 #define _PyUnicode_FromStringAndSize(arg1, arg2) \
57  PyString_FromStringAndSize((arg1), (arg2))
58 #define _PyBytes_FromStringAndSize(arg1, arg2) \
59  PyString_FromStringAndSize((arg1), (arg2))
60 #define _PyLong_FromLong(arg) \
61  PyInt_FromLong(arg)
62 #define _PyLong_AsLong(arg) \
63  PyInt_AsLong(arg)
64 #define _PyCapsule_New(arg1, arg2, arg3) \
65  PyCObject_FromVoidPtr((arg1), (arg2))
66 
67 PyMODINIT_FUNC initperf_trace_context(void);
68 #else
69 #define _PyUnicode_FromString(arg) \
70  PyUnicode_FromString(arg)
71 #define _PyUnicode_FromStringAndSize(arg1, arg2) \
72  PyUnicode_FromStringAndSize((arg1), (arg2))
73 #define _PyBytes_FromStringAndSize(arg1, arg2) \
74  PyBytes_FromStringAndSize((arg1), (arg2))
75 #define _PyLong_FromLong(arg) \
76  PyLong_FromLong(arg)
77 #define _PyLong_AsLong(arg) \
78  PyLong_AsLong(arg)
79 #define _PyCapsule_New(arg1, arg2, arg3) \
80  PyCapsule_New((arg1), (arg2), (arg3))
81 
82 PyMODINIT_FUNC PyInit_perf_trace_context(void);
83 #endif
84 
85 #define TRACE_EVENT_TYPE_MAX \
86  ((1 << (sizeof(unsigned short) * 8)) - 1)
87 
88 static DECLARE_BITMAP(events_defined, TRACE_EVENT_TYPE_MAX);
89 
90 #define MAX_FIELDS 64
91 #define N_COMMON_FIELDS 7
92 
94 
95 static char *cur_field_name;
96 static int zero_flag_atom;
97 
98 static PyObject *main_module, *main_dict;
99 
100 struct tables {
101  struct db_export dbe;
102  PyObject *evsel_handler;
103  PyObject *machine_handler;
104  PyObject *thread_handler;
105  PyObject *comm_handler;
107  PyObject *dso_handler;
108  PyObject *symbol_handler;
110  PyObject *sample_handler;
111  PyObject *call_path_handler;
114 };
115 
116 static struct tables tables_global;
117 
118 static void handler_call_die(const char *handler_name) __noreturn;
119 static void handler_call_die(const char *handler_name)
120 {
121  PyErr_Print();
122  Py_FatalError("problem in Python trace event handler");
123  // Py_FatalError does not return
124  // but we have to make the compiler happy
125  abort();
126 }
127 
128 /*
129  * Insert val into into the dictionary and decrement the reference counter.
130  * This is necessary for dictionaries since PyDict_SetItemString() does not
131  * steal a reference, as opposed to PyTuple_SetItem().
132  */
133 static void pydict_set_item_string_decref(PyObject *dict, const char *key, PyObject *val)
134 {
135  PyDict_SetItemString(dict, key, val);
136  Py_DECREF(val);
137 }
138 
139 static PyObject *get_handler(const char *handler_name)
140 {
141  PyObject *handler;
142 
143  handler = PyDict_GetItemString(main_dict, handler_name);
144  if (handler && !PyCallable_Check(handler))
145  return NULL;
146  return handler;
147 }
148 
149 static int get_argument_count(PyObject *handler)
150 {
151  int arg_count = 0;
152 
153  /*
154  * The attribute for the code object is func_code in Python 2,
155  * whereas it is __code__ in Python 3.0+.
156  */
157  PyObject *code_obj = PyObject_GetAttrString(handler,
158  "func_code");
159  if (PyErr_Occurred()) {
160  PyErr_Clear();
161  code_obj = PyObject_GetAttrString(handler,
162  "__code__");
163  }
164  PyErr_Clear();
165  if (code_obj) {
166  PyObject *arg_count_obj = PyObject_GetAttrString(code_obj,
167  "co_argcount");
168  if (arg_count_obj) {
169  arg_count = (int) _PyLong_AsLong(arg_count_obj);
170  Py_DECREF(arg_count_obj);
171  }
172  Py_DECREF(code_obj);
173  }
174  return arg_count;
175 }
176 
177 static void call_object(PyObject *handler, PyObject *args, const char *die_msg)
178 {
179  PyObject *retval;
180 
181  retval = PyObject_CallObject(handler, args);
182  if (retval == NULL)
183  handler_call_die(die_msg);
184  Py_DECREF(retval);
185 }
186 
187 static void try_call_object(const char *handler_name, PyObject *args)
188 {
189  PyObject *handler;
190 
191  handler = get_handler(handler_name);
192  if (handler)
193  call_object(handler, args, handler_name);
194 }
195 
196 static void define_value(enum print_arg_type field_type,
197  const char *ev_name,
198  const char *field_name,
199  const char *field_value,
200  const char *field_str)
201 {
202  const char *handler_name = "define_flag_value";
203  PyObject *t;
204  unsigned long long value;
205  unsigned n = 0;
206 
207  if (field_type == PRINT_SYMBOL)
208  handler_name = "define_symbolic_value";
209 
210  t = PyTuple_New(4);
211  if (!t)
212  Py_FatalError("couldn't create Python tuple");
213 
214  value = eval_flag(field_value);
215 
216  PyTuple_SetItem(t, n++, _PyUnicode_FromString(ev_name));
217  PyTuple_SetItem(t, n++, _PyUnicode_FromString(field_name));
218  PyTuple_SetItem(t, n++, _PyLong_FromLong(value));
219  PyTuple_SetItem(t, n++, _PyUnicode_FromString(field_str));
220 
221  try_call_object(handler_name, t);
222 
223  Py_DECREF(t);
224 }
225 
226 static void define_values(enum print_arg_type field_type,
227  struct print_flag_sym *field,
228  const char *ev_name,
229  const char *field_name)
230 {
231  define_value(field_type, ev_name, field_name, field->value,
232  field->str);
233 
234  if (field->next)
235  define_values(field_type, field->next, ev_name, field_name);
236 }
237 
238 static void define_field(enum print_arg_type field_type,
239  const char *ev_name,
240  const char *field_name,
241  const char *delim)
242 {
243  const char *handler_name = "define_flag_field";
244  PyObject *t;
245  unsigned n = 0;
246 
247  if (field_type == PRINT_SYMBOL)
248  handler_name = "define_symbolic_field";
249 
250  if (field_type == PRINT_FLAGS)
251  t = PyTuple_New(3);
252  else
253  t = PyTuple_New(2);
254  if (!t)
255  Py_FatalError("couldn't create Python tuple");
256 
257  PyTuple_SetItem(t, n++, _PyUnicode_FromString(ev_name));
258  PyTuple_SetItem(t, n++, _PyUnicode_FromString(field_name));
259  if (field_type == PRINT_FLAGS)
260  PyTuple_SetItem(t, n++, _PyUnicode_FromString(delim));
261 
262  try_call_object(handler_name, t);
263 
264  Py_DECREF(t);
265 }
266 
267 static void define_event_symbols(struct event_format *event,
268  const char *ev_name,
269  struct print_arg *args)
270 {
271  if (args == NULL)
272  return;
273 
274  switch (args->type) {
275  case PRINT_NULL:
276  break;
277  case PRINT_ATOM:
278  define_value(PRINT_FLAGS, ev_name, cur_field_name, "0",
279  args->atom.atom);
280  zero_flag_atom = 0;
281  break;
282  case PRINT_FIELD:
284  cur_field_name = strdup(args->field.name);
285  break;
286  case PRINT_FLAGS:
287  define_event_symbols(event, ev_name, args->flags.field);
288  define_field(PRINT_FLAGS, ev_name, cur_field_name,
289  args->flags.delim);
290  define_values(PRINT_FLAGS, args->flags.flags, ev_name,
292  break;
293  case PRINT_SYMBOL:
294  define_event_symbols(event, ev_name, args->symbol.field);
295  define_field(PRINT_SYMBOL, ev_name, cur_field_name, NULL);
296  define_values(PRINT_SYMBOL, args->symbol.symbols, ev_name,
298  break;
299  case PRINT_HEX:
300  case PRINT_HEX_STR:
301  define_event_symbols(event, ev_name, args->hex.field);
302  define_event_symbols(event, ev_name, args->hex.size);
303  break;
304  case PRINT_INT_ARRAY:
305  define_event_symbols(event, ev_name, args->int_array.field);
306  define_event_symbols(event, ev_name, args->int_array.count);
307  define_event_symbols(event, ev_name, args->int_array.el_size);
308  break;
309  case PRINT_STRING:
310  break;
311  case PRINT_TYPE:
312  define_event_symbols(event, ev_name, args->typecast.item);
313  break;
314  case PRINT_OP:
315  if (strcmp(args->op.op, ":") == 0)
316  zero_flag_atom = 1;
317  define_event_symbols(event, ev_name, args->op.left);
318  define_event_symbols(event, ev_name, args->op.right);
319  break;
320  default:
321  /* gcc warns for these? */
322  case PRINT_BSTRING:
323  case PRINT_DYNAMIC_ARRAY:
324  case PRINT_DYNAMIC_ARRAY_LEN:
325  case PRINT_FUNC:
326  case PRINT_BITMASK:
327  /* we should warn... */
328  return;
329  }
330 
331  if (args->next)
332  define_event_symbols(event, ev_name, args->next);
333 }
334 
335 static PyObject *get_field_numeric_entry(struct event_format *event,
336  struct format_field *field, void *data)
337 {
338  bool is_array = field->flags & FIELD_IS_ARRAY;
339  PyObject *obj = NULL, *list = NULL;
340  unsigned long long val;
341  unsigned int item_size, n_items, i;
342 
343  if (is_array) {
344  list = PyList_New(field->arraylen);
345  item_size = field->size / field->arraylen;
346  n_items = field->arraylen;
347  } else {
348  item_size = field->size;
349  n_items = 1;
350  }
351 
352  for (i = 0; i < n_items; i++) {
353 
354  val = read_size(event, data + field->offset + i * item_size,
355  item_size);
356  if (field->flags & FIELD_IS_SIGNED) {
357  if ((long long)val >= LONG_MIN &&
358  (long long)val <= LONG_MAX)
359  obj = _PyLong_FromLong(val);
360  else
361  obj = PyLong_FromLongLong(val);
362  } else {
363  if (val <= LONG_MAX)
364  obj = _PyLong_FromLong(val);
365  else
366  obj = PyLong_FromUnsignedLongLong(val);
367  }
368  if (is_array)
369  PyList_SET_ITEM(list, i, obj);
370  }
371  if (is_array)
372  obj = list;
373  return obj;
374 }
375 
376 static const char *get_dsoname(struct map *map)
377 {
378  const char *dsoname = "[unknown]";
379 
380  if (map && map->dso) {
382  dsoname = map->dso->long_name;
383  else
384  dsoname = map->dso->name;
385  }
386 
387  return dsoname;
388 }
389 
390 static PyObject *python_process_callchain(struct perf_sample *sample,
391  struct perf_evsel *evsel,
392  struct addr_location *al)
393 {
394  PyObject *pylist;
395 
396  pylist = PyList_New(0);
397  if (!pylist)
398  Py_FatalError("couldn't create Python list");
399 
400  if (!symbol_conf.use_callchain || !sample->callchain)
401  goto exit;
402 
404  sample, NULL, NULL,
405  scripting_max_stack) != 0) {
406  pr_err("Failed to resolve callchain. Skipping\n");
407  goto exit;
408  }
410 
411 
412  while (1) {
413  PyObject *pyelem;
414  struct callchain_cursor_node *node;
416  if (!node)
417  break;
418 
419  pyelem = PyDict_New();
420  if (!pyelem)
421  Py_FatalError("couldn't create Python dictionary");
422 
423 
424  pydict_set_item_string_decref(pyelem, "ip",
425  PyLong_FromUnsignedLongLong(node->ip));
426 
427  if (node->sym) {
428  PyObject *pysym = PyDict_New();
429  if (!pysym)
430  Py_FatalError("couldn't create Python dictionary");
431  pydict_set_item_string_decref(pysym, "start",
432  PyLong_FromUnsignedLongLong(node->sym->start));
433  pydict_set_item_string_decref(pysym, "end",
434  PyLong_FromUnsignedLongLong(node->sym->end));
435  pydict_set_item_string_decref(pysym, "binding",
436  _PyLong_FromLong(node->sym->binding));
437  pydict_set_item_string_decref(pysym, "name",
439  node->sym->namelen));
440  pydict_set_item_string_decref(pyelem, "sym", pysym);
441  }
442 
443  if (node->map) {
444  const char *dsoname = get_dsoname(node->map);
445 
446  pydict_set_item_string_decref(pyelem, "dso",
447  _PyUnicode_FromString(dsoname));
448  }
449 
451  PyList_Append(pylist, pyelem);
452  Py_DECREF(pyelem);
453  }
454 
455 exit:
456  return pylist;
457 }
458 
459 static PyObject *python_process_brstack(struct perf_sample *sample,
460  struct thread *thread)
461 {
462  struct branch_stack *br = sample->branch_stack;
463  PyObject *pylist;
464  u64 i;
465 
466  pylist = PyList_New(0);
467  if (!pylist)
468  Py_FatalError("couldn't create Python list");
469 
470  if (!(br && br->nr))
471  goto exit;
472 
473  for (i = 0; i < br->nr; i++) {
474  PyObject *pyelem;
475  struct addr_location al;
476  const char *dsoname;
477 
478  pyelem = PyDict_New();
479  if (!pyelem)
480  Py_FatalError("couldn't create Python dictionary");
481 
482  pydict_set_item_string_decref(pyelem, "from",
483  PyLong_FromUnsignedLongLong(br->entries[i].from));
484  pydict_set_item_string_decref(pyelem, "to",
485  PyLong_FromUnsignedLongLong(br->entries[i].to));
486  pydict_set_item_string_decref(pyelem, "mispred",
487  PyBool_FromLong(br->entries[i].flags.mispred));
488  pydict_set_item_string_decref(pyelem, "predicted",
489  PyBool_FromLong(br->entries[i].flags.predicted));
490  pydict_set_item_string_decref(pyelem, "in_tx",
491  PyBool_FromLong(br->entries[i].flags.in_tx));
492  pydict_set_item_string_decref(pyelem, "abort",
493  PyBool_FromLong(br->entries[i].flags.abort));
494  pydict_set_item_string_decref(pyelem, "cycles",
495  PyLong_FromUnsignedLongLong(br->entries[i].flags.cycles));
496 
497  thread__find_map(thread, sample->cpumode,
498  br->entries[i].from, &al);
499  dsoname = get_dsoname(al.map);
500  pydict_set_item_string_decref(pyelem, "from_dsoname",
501  _PyUnicode_FromString(dsoname));
502 
503  thread__find_map(thread, sample->cpumode,
504  br->entries[i].to, &al);
505  dsoname = get_dsoname(al.map);
506  pydict_set_item_string_decref(pyelem, "to_dsoname",
507  _PyUnicode_FromString(dsoname));
508 
509  PyList_Append(pylist, pyelem);
510  Py_DECREF(pyelem);
511  }
512 
513 exit:
514  return pylist;
515 }
516 
517 static unsigned long get_offset(struct symbol *sym, struct addr_location *al)
518 {
519  unsigned long offset;
520 
521  if (al->addr < sym->end)
522  offset = al->addr - sym->start;
523  else
524  offset = al->addr - al->map->start - sym->start;
525 
526  return offset;
527 }
528 
529 static int get_symoff(struct symbol *sym, struct addr_location *al,
530  bool print_off, char *bf, int size)
531 {
532  unsigned long offset;
533 
534  if (!sym || !sym->name[0])
535  return scnprintf(bf, size, "%s", "[unknown]");
536 
537  if (!print_off)
538  return scnprintf(bf, size, "%s", sym->name);
539 
540  offset = get_offset(sym, al);
541 
542  return scnprintf(bf, size, "%s+0x%x", sym->name, offset);
543 }
544 
545 static int get_br_mspred(struct branch_flags *flags, char *bf, int size)
546 {
547  if (!flags->mispred && !flags->predicted)
548  return scnprintf(bf, size, "%s", "-");
549 
550  if (flags->mispred)
551  return scnprintf(bf, size, "%s", "M");
552 
553  return scnprintf(bf, size, "%s", "P");
554 }
555 
557  struct thread *thread)
558 {
559  struct branch_stack *br = sample->branch_stack;
560  PyObject *pylist;
561  u64 i;
562  char bf[512];
563  struct addr_location al;
564 
565  pylist = PyList_New(0);
566  if (!pylist)
567  Py_FatalError("couldn't create Python list");
568 
569  if (!(br && br->nr))
570  goto exit;
571 
572  for (i = 0; i < br->nr; i++) {
573  PyObject *pyelem;
574 
575  pyelem = PyDict_New();
576  if (!pyelem)
577  Py_FatalError("couldn't create Python dictionary");
578 
579  thread__find_symbol(thread, sample->cpumode,
580  br->entries[i].from, &al);
581  get_symoff(al.sym, &al, true, bf, sizeof(bf));
582  pydict_set_item_string_decref(pyelem, "from",
584 
585  thread__find_symbol(thread, sample->cpumode,
586  br->entries[i].to, &al);
587  get_symoff(al.sym, &al, true, bf, sizeof(bf));
588  pydict_set_item_string_decref(pyelem, "to",
590 
591  get_br_mspred(&br->entries[i].flags, bf, sizeof(bf));
592  pydict_set_item_string_decref(pyelem, "pred",
594 
595  if (br->entries[i].flags.in_tx) {
596  pydict_set_item_string_decref(pyelem, "in_tx",
597  _PyUnicode_FromString("X"));
598  } else {
599  pydict_set_item_string_decref(pyelem, "in_tx",
600  _PyUnicode_FromString("-"));
601  }
602 
603  if (br->entries[i].flags.abort) {
604  pydict_set_item_string_decref(pyelem, "abort",
605  _PyUnicode_FromString("A"));
606  } else {
607  pydict_set_item_string_decref(pyelem, "abort",
608  _PyUnicode_FromString("-"));
609  }
610 
611  PyList_Append(pylist, pyelem);
612  Py_DECREF(pyelem);
613  }
614 
615 exit:
616  return pylist;
617 }
618 
620 {
621  PyObject *t;
622 
623  t = PyTuple_New(2);
624  if (!t)
625  Py_FatalError("couldn't create Python tuple");
626  PyTuple_SetItem(t, 0, PyLong_FromUnsignedLongLong(value->id));
627  PyTuple_SetItem(t, 1, PyLong_FromUnsignedLongLong(value->value));
628  return t;
629 }
630 
631 static void set_sample_read_in_dict(PyObject *dict_sample,
632  struct perf_sample *sample,
633  struct perf_evsel *evsel)
634 {
635  u64 read_format = evsel->attr.read_format;
636  PyObject *values;
637  unsigned int i;
638 
639  if (read_format & PERF_FORMAT_TOTAL_TIME_ENABLED) {
640  pydict_set_item_string_decref(dict_sample, "time_enabled",
641  PyLong_FromUnsignedLongLong(sample->read.time_enabled));
642  }
643 
644  if (read_format & PERF_FORMAT_TOTAL_TIME_RUNNING) {
645  pydict_set_item_string_decref(dict_sample, "time_running",
646  PyLong_FromUnsignedLongLong(sample->read.time_running));
647  }
648 
649  if (read_format & PERF_FORMAT_GROUP)
650  values = PyList_New(sample->read.group.nr);
651  else
652  values = PyList_New(1);
653 
654  if (!values)
655  Py_FatalError("couldn't create Python list");
656 
657  if (read_format & PERF_FORMAT_GROUP) {
658  for (i = 0; i < sample->read.group.nr; i++) {
659  PyObject *t = get_sample_value_as_tuple(&sample->read.group.values[i]);
660  PyList_SET_ITEM(values, i, t);
661  }
662  } else {
663  PyObject *t = get_sample_value_as_tuple(&sample->read.one);
664  PyList_SET_ITEM(values, 0, t);
665  }
666  pydict_set_item_string_decref(dict_sample, "values", values);
667 }
668 
669 static void set_sample_datasrc_in_dict(PyObject *dict,
670  struct perf_sample *sample)
671 {
672  struct mem_info mi = { .data_src.val = sample->data_src };
673  char decode[100];
674 
675  pydict_set_item_string_decref(dict, "datasrc",
676  PyLong_FromUnsignedLongLong(sample->data_src));
677 
678  perf_script__meminfo_scnprintf(decode, 100, &mi);
679 
680  pydict_set_item_string_decref(dict, "datasrc_decode",
681  _PyUnicode_FromString(decode));
682 }
683 
684 static int regs_map(struct regs_dump *regs, uint64_t mask, char *bf, int size)
685 {
686  unsigned int i = 0, r;
687  int printed = 0;
688 
689  bf[0] = 0;
690 
691  for_each_set_bit(r, (unsigned long *) &mask, sizeof(mask) * 8) {
692  u64 val = regs->regs[i++];
693 
694  printed += scnprintf(bf + printed, size - printed,
695  "%5s:0x%" PRIx64 " ",
696  perf_reg_name(r), val);
697  }
698 
699  return printed;
700 }
701 
702 static void set_regs_in_dict(PyObject *dict,
703  struct perf_sample *sample,
704  struct perf_evsel *evsel)
705 {
706  struct perf_event_attr *attr = &evsel->attr;
707  char bf[512];
708 
709  regs_map(&sample->intr_regs, attr->sample_regs_intr, bf, sizeof(bf));
710 
711  pydict_set_item_string_decref(dict, "iregs",
713 
714  regs_map(&sample->user_regs, attr->sample_regs_user, bf, sizeof(bf));
715 
716  pydict_set_item_string_decref(dict, "uregs",
718 }
719 
720 static PyObject *get_perf_sample_dict(struct perf_sample *sample,
721  struct perf_evsel *evsel,
722  struct addr_location *al,
723  PyObject *callchain)
724 {
725  PyObject *dict, *dict_sample, *brstack, *brstacksym;
726 
727  dict = PyDict_New();
728  if (!dict)
729  Py_FatalError("couldn't create Python dictionary");
730 
731  dict_sample = PyDict_New();
732  if (!dict_sample)
733  Py_FatalError("couldn't create Python dictionary");
734 
737  (const char *)&evsel->attr, sizeof(evsel->attr)));
738 
739  pydict_set_item_string_decref(dict_sample, "pid",
740  _PyLong_FromLong(sample->pid));
741  pydict_set_item_string_decref(dict_sample, "tid",
742  _PyLong_FromLong(sample->tid));
743  pydict_set_item_string_decref(dict_sample, "cpu",
744  _PyLong_FromLong(sample->cpu));
745  pydict_set_item_string_decref(dict_sample, "ip",
746  PyLong_FromUnsignedLongLong(sample->ip));
747  pydict_set_item_string_decref(dict_sample, "time",
748  PyLong_FromUnsignedLongLong(sample->time));
749  pydict_set_item_string_decref(dict_sample, "period",
750  PyLong_FromUnsignedLongLong(sample->period));
751  pydict_set_item_string_decref(dict_sample, "phys_addr",
752  PyLong_FromUnsignedLongLong(sample->phys_addr));
753  pydict_set_item_string_decref(dict_sample, "addr",
754  PyLong_FromUnsignedLongLong(sample->addr));
755  set_sample_read_in_dict(dict_sample, sample, evsel);
756  pydict_set_item_string_decref(dict_sample, "weight",
757  PyLong_FromUnsignedLongLong(sample->weight));
758  pydict_set_item_string_decref(dict_sample, "transaction",
759  PyLong_FromUnsignedLongLong(sample->transaction));
760  set_sample_datasrc_in_dict(dict_sample, sample);
761  pydict_set_item_string_decref(dict, "sample", dict_sample);
762 
764  (const char *)sample->raw_data, sample->raw_size));
765  pydict_set_item_string_decref(dict, "comm",
767  if (al->map) {
768  pydict_set_item_string_decref(dict, "dso",
770  }
771  if (al->sym) {
772  pydict_set_item_string_decref(dict, "symbol",
774  }
775 
776  pydict_set_item_string_decref(dict, "callchain", callchain);
777 
778  brstack = python_process_brstack(sample, al->thread);
779  pydict_set_item_string_decref(dict, "brstack", brstack);
780 
781  brstacksym = python_process_brstacksym(sample, al->thread);
782  pydict_set_item_string_decref(dict, "brstacksym", brstacksym);
783 
784  set_regs_in_dict(dict, sample, evsel);
785 
786  return dict;
787 }
788 
790  struct perf_evsel *evsel,
791  struct addr_location *al)
792 {
793  struct event_format *event = evsel->tp_format;
794  PyObject *handler, *context, *t, *obj = NULL, *callchain;
795  PyObject *dict = NULL, *all_entries_dict = NULL;
796  static char handler_name[256];
797  struct format_field *field;
798  unsigned long s, ns;
799  unsigned n = 0;
800  int pid;
801  int cpu = sample->cpu;
802  void *data = sample->raw_data;
803  unsigned long long nsecs = sample->time;
804  const char *comm = thread__comm_str(al->thread);
805  const char *default_handler_name = "trace_unhandled";
806 
807  if (!event) {
808  snprintf(handler_name, sizeof(handler_name),
809  "ug! no event found for type %" PRIu64, (u64)evsel->attr.config);
810  Py_FatalError(handler_name);
811  }
812 
813  pid = raw_field_value(event, "common_pid", data);
814 
815  sprintf(handler_name, "%s__%s", event->system, event->name);
816 
817  if (!test_and_set_bit(event->id, events_defined))
818  define_event_symbols(event, handler_name, event->print_fmt.args);
819 
820  handler = get_handler(handler_name);
821  if (!handler) {
822  handler = get_handler(default_handler_name);
823  if (!handler)
824  return;
825  dict = PyDict_New();
826  if (!dict)
827  Py_FatalError("couldn't create Python dict");
828  }
829 
830  t = PyTuple_New(MAX_FIELDS);
831  if (!t)
832  Py_FatalError("couldn't create Python tuple");
833 
834 
835  s = nsecs / NSEC_PER_SEC;
836  ns = nsecs - s * NSEC_PER_SEC;
837 
838  scripting_context->event_data = data;
839  scripting_context->pevent = evsel->tp_format->pevent;
840 
841  context = _PyCapsule_New(scripting_context, NULL, NULL);
842 
843  PyTuple_SetItem(t, n++, _PyUnicode_FromString(handler_name));
844  PyTuple_SetItem(t, n++, context);
845 
846  /* ip unwinding */
847  callchain = python_process_callchain(sample, evsel, al);
848  /* Need an additional reference for the perf_sample dict */
849  Py_INCREF(callchain);
850 
851  if (!dict) {
852  PyTuple_SetItem(t, n++, _PyLong_FromLong(cpu));
853  PyTuple_SetItem(t, n++, _PyLong_FromLong(s));
854  PyTuple_SetItem(t, n++, _PyLong_FromLong(ns));
855  PyTuple_SetItem(t, n++, _PyLong_FromLong(pid));
856  PyTuple_SetItem(t, n++, _PyUnicode_FromString(comm));
857  PyTuple_SetItem(t, n++, callchain);
858  } else {
859  pydict_set_item_string_decref(dict, "common_cpu", _PyLong_FromLong(cpu));
860  pydict_set_item_string_decref(dict, "common_s", _PyLong_FromLong(s));
861  pydict_set_item_string_decref(dict, "common_ns", _PyLong_FromLong(ns));
862  pydict_set_item_string_decref(dict, "common_pid", _PyLong_FromLong(pid));
863  pydict_set_item_string_decref(dict, "common_comm", _PyUnicode_FromString(comm));
864  pydict_set_item_string_decref(dict, "common_callchain", callchain);
865  }
866  for (field = event->format.fields; field; field = field->next) {
867  unsigned int offset, len;
868  unsigned long long val;
869 
870  if (field->flags & FIELD_IS_ARRAY) {
871  offset = field->offset;
872  len = field->size;
873  if (field->flags & FIELD_IS_DYNAMIC) {
874  val = pevent_read_number(scripting_context->pevent,
875  data + offset, len);
876  offset = val;
877  len = offset >> 16;
878  offset &= 0xffff;
879  }
880  if (field->flags & FIELD_IS_STRING &&
881  is_printable_array(data + offset, len)) {
882  obj = _PyUnicode_FromString((char *) data + offset);
883  } else {
884  obj = PyByteArray_FromStringAndSize((const char *) data + offset, len);
885  field->flags &= ~FIELD_IS_STRING;
886  }
887  } else { /* FIELD_IS_NUMERIC */
888  obj = get_field_numeric_entry(event, field, data);
889  }
890  if (!dict)
891  PyTuple_SetItem(t, n++, obj);
892  else
893  pydict_set_item_string_decref(dict, field->name, obj);
894 
895  }
896 
897  if (dict)
898  PyTuple_SetItem(t, n++, dict);
899 
900  if (get_argument_count(handler) == (int) n + 1) {
901  all_entries_dict = get_perf_sample_dict(sample, evsel, al,
902  callchain);
903  PyTuple_SetItem(t, n++, all_entries_dict);
904  } else {
905  Py_DECREF(callchain);
906  }
907 
908  if (_PyTuple_Resize(&t, n) == -1)
909  Py_FatalError("error resizing Python tuple");
910 
911  if (!dict) {
912  call_object(handler, t, handler_name);
913  } else {
914  call_object(handler, t, default_handler_name);
915  Py_DECREF(dict);
916  }
917 
918  Py_XDECREF(all_entries_dict);
919  Py_DECREF(t);
920 }
921 
922 static PyObject *tuple_new(unsigned int sz)
923 {
924  PyObject *t;
925 
926  t = PyTuple_New(sz);
927  if (!t)
928  Py_FatalError("couldn't create Python tuple");
929  return t;
930 }
931 
932 static int tuple_set_u64(PyObject *t, unsigned int pos, u64 val)
933 {
934 #if BITS_PER_LONG == 64
935  return PyTuple_SetItem(t, pos, _PyLong_FromLong(val));
936 #endif
937 #if BITS_PER_LONG == 32
938  return PyTuple_SetItem(t, pos, PyLong_FromLongLong(val));
939 #endif
940 }
941 
942 static int tuple_set_s32(PyObject *t, unsigned int pos, s32 val)
943 {
944  return PyTuple_SetItem(t, pos, _PyLong_FromLong(val));
945 }
946 
947 static int tuple_set_string(PyObject *t, unsigned int pos, const char *s)
948 {
949  return PyTuple_SetItem(t, pos, _PyUnicode_FromString(s));
950 }
951 
952 static int python_export_evsel(struct db_export *dbe, struct perf_evsel *evsel)
953 {
954  struct tables *tables = container_of(dbe, struct tables, dbe);
955  PyObject *t;
956 
957  t = tuple_new(2);
958 
959  tuple_set_u64(t, 0, evsel->db_id);
960  tuple_set_string(t, 1, perf_evsel__name(evsel));
961 
962  call_object(tables->evsel_handler, t, "evsel_table");
963 
964  Py_DECREF(t);
965 
966  return 0;
967 }
968 
970  struct machine *machine)
971 {
972  struct tables *tables = container_of(dbe, struct tables, dbe);
973  PyObject *t;
974 
975  t = tuple_new(3);
976 
977  tuple_set_u64(t, 0, machine->db_id);
978  tuple_set_s32(t, 1, machine->pid);
979  tuple_set_string(t, 2, machine->root_dir ? machine->root_dir : "");
980 
981  call_object(tables->machine_handler, t, "machine_table");
982 
983  Py_DECREF(t);
984 
985  return 0;
986 }
987 
988 static int python_export_thread(struct db_export *dbe, struct thread *thread,
989  u64 main_thread_db_id, struct machine *machine)
990 {
991  struct tables *tables = container_of(dbe, struct tables, dbe);
992  PyObject *t;
993 
994  t = tuple_new(5);
995 
996  tuple_set_u64(t, 0, thread->db_id);
997  tuple_set_u64(t, 1, machine->db_id);
998  tuple_set_u64(t, 2, main_thread_db_id);
999  tuple_set_s32(t, 3, thread->pid_);
1000  tuple_set_s32(t, 4, thread->tid);
1001 
1002  call_object(tables->thread_handler, t, "thread_table");
1003 
1004  Py_DECREF(t);
1005 
1006  return 0;
1007 }
1008 
1009 static int python_export_comm(struct db_export *dbe, struct comm *comm)
1010 {
1011  struct tables *tables = container_of(dbe, struct tables, dbe);
1012  PyObject *t;
1013 
1014  t = tuple_new(2);
1015 
1016  tuple_set_u64(t, 0, comm->db_id);
1017  tuple_set_string(t, 1, comm__str(comm));
1018 
1019  call_object(tables->comm_handler, t, "comm_table");
1020 
1021  Py_DECREF(t);
1022 
1023  return 0;
1024 }
1025 
1026 static int python_export_comm_thread(struct db_export *dbe, u64 db_id,
1027  struct comm *comm, struct thread *thread)
1028 {
1029  struct tables *tables = container_of(dbe, struct tables, dbe);
1030  PyObject *t;
1031 
1032  t = tuple_new(3);
1033 
1034  tuple_set_u64(t, 0, db_id);
1035  tuple_set_u64(t, 1, comm->db_id);
1036  tuple_set_u64(t, 2, thread->db_id);
1037 
1038  call_object(tables->comm_thread_handler, t, "comm_thread_table");
1039 
1040  Py_DECREF(t);
1041 
1042  return 0;
1043 }
1044 
1045 static int python_export_dso(struct db_export *dbe, struct dso *dso,
1046  struct machine *machine)
1047 {
1048  struct tables *tables = container_of(dbe, struct tables, dbe);
1049  char sbuild_id[SBUILD_ID_SIZE];
1050  PyObject *t;
1051 
1052  build_id__sprintf(dso->build_id, sizeof(dso->build_id), sbuild_id);
1053 
1054  t = tuple_new(5);
1055 
1056  tuple_set_u64(t, 0, dso->db_id);
1057  tuple_set_u64(t, 1, machine->db_id);
1058  tuple_set_string(t, 2, dso->short_name);
1059  tuple_set_string(t, 3, dso->long_name);
1060  tuple_set_string(t, 4, sbuild_id);
1061 
1062  call_object(tables->dso_handler, t, "dso_table");
1063 
1064  Py_DECREF(t);
1065 
1066  return 0;
1067 }
1068 
1069 static int python_export_symbol(struct db_export *dbe, struct symbol *sym,
1070  struct dso *dso)
1071 {
1072  struct tables *tables = container_of(dbe, struct tables, dbe);
1073  u64 *sym_db_id = symbol__priv(sym);
1074  PyObject *t;
1075 
1076  t = tuple_new(6);
1077 
1078  tuple_set_u64(t, 0, *sym_db_id);
1079  tuple_set_u64(t, 1, dso->db_id);
1080  tuple_set_u64(t, 2, sym->start);
1081  tuple_set_u64(t, 3, sym->end);
1082  tuple_set_s32(t, 4, sym->binding);
1083  tuple_set_string(t, 5, sym->name);
1084 
1085  call_object(tables->symbol_handler, t, "symbol_table");
1086 
1087  Py_DECREF(t);
1088 
1089  return 0;
1090 }
1091 
1093  const char *name)
1094 {
1095  struct tables *tables = container_of(dbe, struct tables, dbe);
1096  PyObject *t;
1097 
1098  t = tuple_new(2);
1099 
1100  tuple_set_s32(t, 0, branch_type);
1101  tuple_set_string(t, 1, name);
1102 
1103  call_object(tables->branch_type_handler, t, "branch_type_table");
1104 
1105  Py_DECREF(t);
1106 
1107  return 0;
1108 }
1109 
1111  struct export_sample *es)
1112 {
1113  struct tables *tables = container_of(dbe, struct tables, dbe);
1114  PyObject *t;
1115 
1116  t = tuple_new(22);
1117 
1118  tuple_set_u64(t, 0, es->db_id);
1119  tuple_set_u64(t, 1, es->evsel->db_id);
1120  tuple_set_u64(t, 2, es->al->machine->db_id);
1121  tuple_set_u64(t, 3, es->al->thread->db_id);
1122  tuple_set_u64(t, 4, es->comm_db_id);
1123  tuple_set_u64(t, 5, es->dso_db_id);
1124  tuple_set_u64(t, 6, es->sym_db_id);
1125  tuple_set_u64(t, 7, es->offset);
1126  tuple_set_u64(t, 8, es->sample->ip);
1127  tuple_set_u64(t, 9, es->sample->time);
1128  tuple_set_s32(t, 10, es->sample->cpu);
1129  tuple_set_u64(t, 11, es->addr_dso_db_id);
1130  tuple_set_u64(t, 12, es->addr_sym_db_id);
1131  tuple_set_u64(t, 13, es->addr_offset);
1132  tuple_set_u64(t, 14, es->sample->addr);
1133  tuple_set_u64(t, 15, es->sample->period);
1134  tuple_set_u64(t, 16, es->sample->weight);
1135  tuple_set_u64(t, 17, es->sample->transaction);
1136  tuple_set_u64(t, 18, es->sample->data_src);
1137  tuple_set_s32(t, 19, es->sample->flags & PERF_BRANCH_MASK);
1138  tuple_set_s32(t, 20, !!(es->sample->flags & PERF_IP_FLAG_IN_TX));
1139  tuple_set_u64(t, 21, es->call_path_id);
1140 
1141  call_object(tables->sample_handler, t, "sample_table");
1142 
1143  Py_DECREF(t);
1144 
1145  return 0;
1146 }
1147 
1148 static int python_export_call_path(struct db_export *dbe, struct call_path *cp)
1149 {
1150  struct tables *tables = container_of(dbe, struct tables, dbe);
1151  PyObject *t;
1152  u64 parent_db_id, sym_db_id;
1153 
1154  parent_db_id = cp->parent ? cp->parent->db_id : 0;
1155  sym_db_id = cp->sym ? *(u64 *)symbol__priv(cp->sym) : 0;
1156 
1157  t = tuple_new(4);
1158 
1159  tuple_set_u64(t, 0, cp->db_id);
1160  tuple_set_u64(t, 1, parent_db_id);
1161  tuple_set_u64(t, 2, sym_db_id);
1162  tuple_set_u64(t, 3, cp->ip);
1163 
1164  call_object(tables->call_path_handler, t, "call_path_table");
1165 
1166  Py_DECREF(t);
1167 
1168  return 0;
1169 }
1170 
1172  struct call_return *cr)
1173 {
1174  struct tables *tables = container_of(dbe, struct tables, dbe);
1175  u64 comm_db_id = cr->comm ? cr->comm->db_id : 0;
1176  PyObject *t;
1177 
1178  t = tuple_new(11);
1179 
1180  tuple_set_u64(t, 0, cr->db_id);
1181  tuple_set_u64(t, 1, cr->thread->db_id);
1182  tuple_set_u64(t, 2, comm_db_id);
1183  tuple_set_u64(t, 3, cr->cp->db_id);
1184  tuple_set_u64(t, 4, cr->call_time);
1185  tuple_set_u64(t, 5, cr->return_time);
1186  tuple_set_u64(t, 6, cr->branch_count);
1187  tuple_set_u64(t, 7, cr->call_ref);
1188  tuple_set_u64(t, 8, cr->return_ref);
1189  tuple_set_u64(t, 9, cr->cp->parent->db_id);
1190  tuple_set_s32(t, 10, cr->flags);
1191 
1192  call_object(tables->call_return_handler, t, "call_return_table");
1193 
1194  Py_DECREF(t);
1195 
1196  return 0;
1197 }
1198 
1199 static int python_process_call_return(struct call_return *cr, void *data)
1200 {
1201  struct db_export *dbe = data;
1202 
1203  return db_export__call_return(dbe, cr);
1204 }
1205 
1207  struct perf_evsel *evsel,
1208  struct addr_location *al)
1209 {
1210  PyObject *handler, *t, *dict, *callchain;
1211  static char handler_name[64];
1212  unsigned n = 0;
1213 
1214  snprintf(handler_name, sizeof(handler_name), "%s", "process_event");
1215 
1216  handler = get_handler(handler_name);
1217  if (!handler)
1218  return;
1219 
1220  /*
1221  * Use the MAX_FIELDS to make the function expandable, though
1222  * currently there is only one item for the tuple.
1223  */
1224  t = PyTuple_New(MAX_FIELDS);
1225  if (!t)
1226  Py_FatalError("couldn't create Python tuple");
1227 
1228  /* ip unwinding */
1229  callchain = python_process_callchain(sample, evsel, al);
1230  dict = get_perf_sample_dict(sample, evsel, al, callchain);
1231 
1232  PyTuple_SetItem(t, n++, dict);
1233  if (_PyTuple_Resize(&t, n) == -1)
1234  Py_FatalError("error resizing Python tuple");
1235 
1236  call_object(handler, t, handler_name);
1237 
1238  Py_DECREF(dict);
1239  Py_DECREF(t);
1240 }
1241 
1243  struct perf_sample *sample,
1244  struct perf_evsel *evsel,
1245  struct addr_location *al)
1246 {
1247  struct tables *tables = &tables_global;
1248 
1249  switch (evsel->attr.type) {
1250  case PERF_TYPE_TRACEPOINT:
1251  python_process_tracepoint(sample, evsel, al);
1252  break;
1253  /* Reserve for future process_hw/sw/raw APIs */
1254  default:
1255  if (tables->db_export_mode)
1256  db_export__sample(&tables->dbe, event, sample, evsel, al);
1257  else
1258  python_process_general_event(sample, evsel, al);
1259  }
1260 }
1261 
1262 static void get_handler_name(char *str, size_t size,
1263  struct perf_evsel *evsel)
1264 {
1265  char *p = str;
1266 
1267  scnprintf(str, size, "stat__%s", perf_evsel__name(evsel));
1268 
1269  while ((p = strchr(p, ':'))) {
1270  *p = '_';
1271  p++;
1272  }
1273 }
1274 
1275 static void
1276 process_stat(struct perf_evsel *counter, int cpu, int thread, u64 tstamp,
1277  struct perf_counts_values *count)
1278 {
1279  PyObject *handler, *t;
1280  static char handler_name[256];
1281  int n = 0;
1282 
1283  t = PyTuple_New(MAX_FIELDS);
1284  if (!t)
1285  Py_FatalError("couldn't create Python tuple");
1286 
1287  get_handler_name(handler_name, sizeof(handler_name),
1288  counter);
1289 
1290  handler = get_handler(handler_name);
1291  if (!handler) {
1292  pr_debug("can't find python handler %s\n", handler_name);
1293  return;
1294  }
1295 
1296  PyTuple_SetItem(t, n++, _PyLong_FromLong(cpu));
1297  PyTuple_SetItem(t, n++, _PyLong_FromLong(thread));
1298 
1299  tuple_set_u64(t, n++, tstamp);
1300  tuple_set_u64(t, n++, count->val);
1301  tuple_set_u64(t, n++, count->ena);
1302  tuple_set_u64(t, n++, count->run);
1303 
1304  if (_PyTuple_Resize(&t, n) == -1)
1305  Py_FatalError("error resizing Python tuple");
1306 
1307  call_object(handler, t, handler_name);
1308 
1309  Py_DECREF(t);
1310 }
1311 
1313  struct perf_evsel *counter, u64 tstamp)
1314 {
1315  struct thread_map *threads = counter->threads;
1316  struct cpu_map *cpus = counter->cpus;
1317  int cpu, thread;
1318 
1319  if (config->aggr_mode == AGGR_GLOBAL) {
1320  process_stat(counter, -1, -1, tstamp,
1321  &counter->counts->aggr);
1322  return;
1323  }
1324 
1325  for (thread = 0; thread < threads->nr; thread++) {
1326  for (cpu = 0; cpu < cpus->nr; cpu++) {
1327  process_stat(counter, cpus->map[cpu],
1328  thread_map__pid(threads, thread), tstamp,
1329  perf_counts(counter->counts, cpu, thread));
1330  }
1331  }
1332 }
1333 
1334 static void python_process_stat_interval(u64 tstamp)
1335 {
1336  PyObject *handler, *t;
1337  static const char handler_name[] = "stat__interval";
1338  int n = 0;
1339 
1340  t = PyTuple_New(MAX_FIELDS);
1341  if (!t)
1342  Py_FatalError("couldn't create Python tuple");
1343 
1344  handler = get_handler(handler_name);
1345  if (!handler) {
1346  pr_debug("can't find python handler %s\n", handler_name);
1347  return;
1348  }
1349 
1350  tuple_set_u64(t, n++, tstamp);
1351 
1352  if (_PyTuple_Resize(&t, n) == -1)
1353  Py_FatalError("error resizing Python tuple");
1354 
1355  call_object(handler, t, handler_name);
1356 
1357  Py_DECREF(t);
1358 }
1359 
1360 static int run_start_sub(void)
1361 {
1362  main_module = PyImport_AddModule("__main__");
1363  if (main_module == NULL)
1364  return -1;
1365  Py_INCREF(main_module);
1366 
1367  main_dict = PyModule_GetDict(main_module);
1368  if (main_dict == NULL)
1369  goto error;
1370  Py_INCREF(main_dict);
1371 
1372  try_call_object("trace_begin", NULL);
1373 
1374  return 0;
1375 
1376 error:
1377  Py_XDECREF(main_dict);
1378  Py_XDECREF(main_module);
1379  return -1;
1380 }
1381 
1382 #define SET_TABLE_HANDLER_(name, handler_name, table_name) do { \
1383  tables->handler_name = get_handler(#table_name); \
1384  if (tables->handler_name) \
1385  tables->dbe.export_ ## name = python_export_ ## name; \
1386 } while (0)
1387 
1388 #define SET_TABLE_HANDLER(name) \
1389  SET_TABLE_HANDLER_(name, name ## _handler, name ## _table)
1390 
1391 static void set_table_handlers(struct tables *tables)
1392 {
1393  const char *perf_db_export_mode = "perf_db_export_mode";
1394  const char *perf_db_export_calls = "perf_db_export_calls";
1395  const char *perf_db_export_callchains = "perf_db_export_callchains";
1396  PyObject *db_export_mode, *db_export_calls, *db_export_callchains;
1397  bool export_calls = false;
1398  bool export_callchains = false;
1399  int ret;
1400 
1401  memset(tables, 0, sizeof(struct tables));
1402  if (db_export__init(&tables->dbe))
1403  Py_FatalError("failed to initialize export");
1404 
1405  db_export_mode = PyDict_GetItemString(main_dict, perf_db_export_mode);
1406  if (!db_export_mode)
1407  return;
1408 
1409  ret = PyObject_IsTrue(db_export_mode);
1410  if (ret == -1)
1411  handler_call_die(perf_db_export_mode);
1412  if (!ret)
1413  return;
1414 
1415  /* handle export calls */
1416  tables->dbe.crp = NULL;
1417  db_export_calls = PyDict_GetItemString(main_dict, perf_db_export_calls);
1418  if (db_export_calls) {
1419  ret = PyObject_IsTrue(db_export_calls);
1420  if (ret == -1)
1421  handler_call_die(perf_db_export_calls);
1422  export_calls = !!ret;
1423  }
1424 
1425  if (export_calls) {
1426  tables->dbe.crp =
1428  &tables->dbe);
1429  if (!tables->dbe.crp)
1430  Py_FatalError("failed to create calls processor");
1431  }
1432 
1433  /* handle export callchains */
1434  tables->dbe.cpr = NULL;
1435  db_export_callchains = PyDict_GetItemString(main_dict,
1436  perf_db_export_callchains);
1437  if (db_export_callchains) {
1438  ret = PyObject_IsTrue(db_export_callchains);
1439  if (ret == -1)
1440  handler_call_die(perf_db_export_callchains);
1441  export_callchains = !!ret;
1442  }
1443 
1444  if (export_callchains) {
1445  /*
1446  * Attempt to use the call path root from the call return
1447  * processor, if the call return processor is in use. Otherwise,
1448  * we allocate a new call path root. This prevents exporting
1449  * duplicate call path ids when both are in use simultaniously.
1450  */
1451  if (tables->dbe.crp)
1452  tables->dbe.cpr = tables->dbe.crp->cpr;
1453  else
1454  tables->dbe.cpr = call_path_root__new();
1455 
1456  if (!tables->dbe.cpr)
1457  Py_FatalError("failed to create call path root");
1458  }
1459 
1460  tables->db_export_mode = true;
1461  /*
1462  * Reserve per symbol space for symbol->db_id via symbol__priv()
1463  */
1464  symbol_conf.priv_size = sizeof(u64);
1465 
1466  SET_TABLE_HANDLER(evsel);
1470  SET_TABLE_HANDLER(comm_thread);
1477 }
1478 
1479 #if PY_MAJOR_VERSION < 3
1480 static void _free_command_line(const char **command_line, int num)
1481 {
1482  free(command_line);
1483 }
1484 #else
1485 static void _free_command_line(wchar_t **command_line, int num)
1486 {
1487  int i;
1488  for (i = 0; i < num; i++)
1489  PyMem_RawFree(command_line[i]);
1490  free(command_line);
1491 }
1492 #endif
1493 
1494 
1495 /*
1496  * Start trace script
1497  */
1498 static int python_start_script(const char *script, int argc, const char **argv)
1499 {
1500  struct tables *tables = &tables_global;
1501 #if PY_MAJOR_VERSION < 3
1502  const char **command_line;
1503 #else
1504  wchar_t **command_line;
1505 #endif
1506  char buf[PATH_MAX];
1507  int i, err = 0;
1508  FILE *fp;
1509 
1510 #if PY_MAJOR_VERSION < 3
1511  command_line = malloc((argc + 1) * sizeof(const char *));
1512  command_line[0] = script;
1513  for (i = 1; i < argc + 1; i++)
1514  command_line[i] = argv[i - 1];
1515 #else
1516  command_line = malloc((argc + 1) * sizeof(wchar_t *));
1517  command_line[0] = Py_DecodeLocale(script, NULL);
1518  for (i = 1; i < argc + 1; i++)
1519  command_line[i] = Py_DecodeLocale(argv[i - 1], NULL);
1520 #endif
1521 
1522  Py_Initialize();
1523 
1524 #if PY_MAJOR_VERSION < 3
1526  PySys_SetArgv(argc + 1, (char **)command_line);
1527 #else
1528  PyInit_perf_trace_context();
1529  PySys_SetArgv(argc + 1, command_line);
1530 #endif
1531 
1532  fp = fopen(script, "r");
1533  if (!fp) {
1534  sprintf(buf, "Can't open python script \"%s\"", script);
1535  perror(buf);
1536  err = -1;
1537  goto error;
1538  }
1539 
1540  err = PyRun_SimpleFile(fp, script);
1541  if (err) {
1542  fprintf(stderr, "Error running python script %s\n", script);
1543  goto error;
1544  }
1545 
1546  err = run_start_sub();
1547  if (err) {
1548  fprintf(stderr, "Error starting python script %s\n", script);
1549  goto error;
1550  }
1551 
1552  set_table_handlers(tables);
1553 
1554  if (tables->db_export_mode) {
1555  err = db_export__branch_types(&tables->dbe);
1556  if (err)
1557  goto error;
1558  }
1559 
1560  _free_command_line(command_line, argc + 1);
1561 
1562  return err;
1563 error:
1564  Py_Finalize();
1565  _free_command_line(command_line, argc + 1);
1566 
1567  return err;
1568 }
1569 
1570 static int python_flush_script(void)
1571 {
1572  struct tables *tables = &tables_global;
1573 
1574  return db_export__flush(&tables->dbe);
1575 }
1576 
1577 /*
1578  * Stop trace script
1579  */
1580 static int python_stop_script(void)
1581 {
1582  struct tables *tables = &tables_global;
1583 
1584  try_call_object("trace_end", NULL);
1585 
1586  db_export__exit(&tables->dbe);
1587 
1588  Py_XDECREF(main_dict);
1589  Py_XDECREF(main_module);
1590  Py_Finalize();
1591 
1592  return 0;
1593 }
1594 
1595 static int python_generate_script(struct pevent *pevent, const char *outfile)
1596 {
1597  struct event_format *event = NULL;
1598  struct format_field *f;
1599  char fname[PATH_MAX];
1600  int not_first, count;
1601  FILE *ofp;
1602 
1603  sprintf(fname, "%s.py", outfile);
1604  ofp = fopen(fname, "w");
1605  if (ofp == NULL) {
1606  fprintf(stderr, "couldn't open %s\n", fname);
1607  return -1;
1608  }
1609  fprintf(ofp, "# perf script event handlers, "
1610  "generated by perf script -g python\n");
1611 
1612  fprintf(ofp, "# Licensed under the terms of the GNU GPL"
1613  " License version 2\n\n");
1614 
1615  fprintf(ofp, "# The common_* event handler fields are the most useful "
1616  "fields common to\n");
1617 
1618  fprintf(ofp, "# all events. They don't necessarily correspond to "
1619  "the 'common_*' fields\n");
1620 
1621  fprintf(ofp, "# in the format files. Those fields not available as "
1622  "handler params can\n");
1623 
1624  fprintf(ofp, "# be retrieved using Python functions of the form "
1625  "common_*(context).\n");
1626 
1627  fprintf(ofp, "# See the perf-script-python Documentation for the list "
1628  "of available functions.\n\n");
1629 
1630  fprintf(ofp, "import os\n");
1631  fprintf(ofp, "import sys\n\n");
1632 
1633  fprintf(ofp, "sys.path.append(os.environ['PERF_EXEC_PATH'] + \\\n");
1634  fprintf(ofp, "\t'/scripts/python/Perf-Trace-Util/lib/Perf/Trace')\n");
1635  fprintf(ofp, "\nfrom perf_trace_context import *\n");
1636  fprintf(ofp, "from Core import *\n\n\n");
1637 
1638  fprintf(ofp, "def trace_begin():\n");
1639  fprintf(ofp, "\tprint \"in trace_begin\"\n\n");
1640 
1641  fprintf(ofp, "def trace_end():\n");
1642  fprintf(ofp, "\tprint \"in trace_end\"\n\n");
1643 
1644  while ((event = trace_find_next_event(pevent, event))) {
1645  fprintf(ofp, "def %s__%s(", event->system, event->name);
1646  fprintf(ofp, "event_name, ");
1647  fprintf(ofp, "context, ");
1648  fprintf(ofp, "common_cpu,\n");
1649  fprintf(ofp, "\tcommon_secs, ");
1650  fprintf(ofp, "common_nsecs, ");
1651  fprintf(ofp, "common_pid, ");
1652  fprintf(ofp, "common_comm,\n\t");
1653  fprintf(ofp, "common_callchain, ");
1654 
1655  not_first = 0;
1656  count = 0;
1657 
1658  for (f = event->format.fields; f; f = f->next) {
1659  if (not_first++)
1660  fprintf(ofp, ", ");
1661  if (++count % 5 == 0)
1662  fprintf(ofp, "\n\t");
1663 
1664  fprintf(ofp, "%s", f->name);
1665  }
1666  if (not_first++)
1667  fprintf(ofp, ", ");
1668  if (++count % 5 == 0)
1669  fprintf(ofp, "\n\t\t");
1670  fprintf(ofp, "perf_sample_dict");
1671 
1672  fprintf(ofp, "):\n");
1673 
1674  fprintf(ofp, "\t\tprint_header(event_name, common_cpu, "
1675  "common_secs, common_nsecs,\n\t\t\t"
1676  "common_pid, common_comm)\n\n");
1677 
1678  fprintf(ofp, "\t\tprint \"");
1679 
1680  not_first = 0;
1681  count = 0;
1682 
1683  for (f = event->format.fields; f; f = f->next) {
1684  if (not_first++)
1685  fprintf(ofp, ", ");
1686  if (count && count % 3 == 0) {
1687  fprintf(ofp, "\" \\\n\t\t\"");
1688  }
1689  count++;
1690 
1691  fprintf(ofp, "%s=", f->name);
1692  if (f->flags & FIELD_IS_STRING ||
1693  f->flags & FIELD_IS_FLAG ||
1694  f->flags & FIELD_IS_ARRAY ||
1695  f->flags & FIELD_IS_SYMBOLIC)
1696  fprintf(ofp, "%%s");
1697  else if (f->flags & FIELD_IS_SIGNED)
1698  fprintf(ofp, "%%d");
1699  else
1700  fprintf(ofp, "%%u");
1701  }
1702 
1703  fprintf(ofp, "\" %% \\\n\t\t(");
1704 
1705  not_first = 0;
1706  count = 0;
1707 
1708  for (f = event->format.fields; f; f = f->next) {
1709  if (not_first++)
1710  fprintf(ofp, ", ");
1711 
1712  if (++count % 5 == 0)
1713  fprintf(ofp, "\n\t\t");
1714 
1715  if (f->flags & FIELD_IS_FLAG) {
1716  if ((count - 1) % 5 != 0) {
1717  fprintf(ofp, "\n\t\t");
1718  count = 4;
1719  }
1720  fprintf(ofp, "flag_str(\"");
1721  fprintf(ofp, "%s__%s\", ", event->system,
1722  event->name);
1723  fprintf(ofp, "\"%s\", %s)", f->name,
1724  f->name);
1725  } else if (f->flags & FIELD_IS_SYMBOLIC) {
1726  if ((count - 1) % 5 != 0) {
1727  fprintf(ofp, "\n\t\t");
1728  count = 4;
1729  }
1730  fprintf(ofp, "symbol_str(\"");
1731  fprintf(ofp, "%s__%s\", ", event->system,
1732  event->name);
1733  fprintf(ofp, "\"%s\", %s)", f->name,
1734  f->name);
1735  } else
1736  fprintf(ofp, "%s", f->name);
1737  }
1738 
1739  fprintf(ofp, ")\n\n");
1740 
1741  fprintf(ofp, "\t\tprint 'Sample: {'+"
1742  "get_dict_as_string(perf_sample_dict['sample'], ', ')+'}'\n\n");
1743 
1744  fprintf(ofp, "\t\tfor node in common_callchain:");
1745  fprintf(ofp, "\n\t\t\tif 'sym' in node:");
1746  fprintf(ofp, "\n\t\t\t\tprint \"\\t[%%x] %%s\" %% (node['ip'], node['sym']['name'])");
1747  fprintf(ofp, "\n\t\t\telse:");
1748  fprintf(ofp, "\n\t\t\t\tprint \"\t[%%x]\" %% (node['ip'])\n\n");
1749  fprintf(ofp, "\t\tprint \"\\n\"\n\n");
1750 
1751  }
1752 
1753  fprintf(ofp, "def trace_unhandled(event_name, context, "
1754  "event_fields_dict, perf_sample_dict):\n");
1755 
1756  fprintf(ofp, "\t\tprint get_dict_as_string(event_fields_dict)\n");
1757  fprintf(ofp, "\t\tprint 'Sample: {'+"
1758  "get_dict_as_string(perf_sample_dict['sample'], ', ')+'}'\n\n");
1759 
1760  fprintf(ofp, "def print_header("
1761  "event_name, cpu, secs, nsecs, pid, comm):\n"
1762  "\tprint \"%%-20s %%5u %%05u.%%09u %%8u %%-20s \" %% \\\n\t"
1763  "(event_name, cpu, secs, nsecs, pid, comm),\n\n");
1764 
1765  fprintf(ofp, "def get_dict_as_string(a_dict, delimiter=' '):\n"
1766  "\treturn delimiter.join"
1767  "(['%%s=%%s'%%(k,str(v))for k,v in sorted(a_dict.items())])\n");
1768 
1769  fclose(ofp);
1770 
1771  fprintf(stderr, "generated Python script: %s\n", fname);
1772 
1773  return 0;
1774 }
1775 
1777  .name = "Python",
1778  .start_script = python_start_script,
1779  .flush_script = python_flush_script,
1780  .stop_script = python_stop_script,
1781  .process_event = python_process_event,
1782  .process_stat = python_process_stat,
1783  .process_stat_interval = python_process_stat_interval,
1784  .generate_script = python_generate_script,
1785 };
int nr
Definition: cpumap.h:14
static int python_export_comm(struct db_export *dbe, struct comm *comm)
Definition: mem2node.c:7
int value
Definition: python.c:1143
u64 addr_dso_db_id
Definition: db-export.h:44
static void python_process_stat(struct perf_stat_config *config, struct perf_evsel *counter, u64 tstamp)
u64 weight
Definition: event.h:199
struct comm * comm
Definition: thread-stack.h:59
struct event_format * trace_find_next_event(struct pevent *pevent, struct event_format *event)
struct addr_location * al
Definition: db-export.h:38
static void handler_call_die(const char *handler_name) __noreturn
static PyObject * python_process_brstack(struct perf_sample *sample, struct thread *thread)
pid_t pid_
Definition: thread.h:24
u32 branch_type
Definition: db-export.c:431
static int tuple_set_s32(PyObject *t, unsigned int pos, s32 val)
u64 data_src
Definition: event.h:203
size_t size
Definition: evsel.c:60
static int get_argument_count(PyObject *handler)
enum aggr_mode aggr_mode
Definition: stat.h:88
struct call_return_processor * call_return_processor__new(int(*process)(struct call_return *cr, void *data), void *data)
Definition: thread-stack.c:305
static PyObject * get_handler(const char *handler_name)
static void python_process_tracepoint(struct perf_sample *sample, struct perf_evsel *evsel, struct addr_location *al)
static void set_table_handlers(struct tables *tables)
u64 addr
Definition: event.h:195
static int regs_map(struct regs_dump *regs, uint64_t mask, char *bf, int size)
static int python_export_call_path(struct db_export *dbe, struct call_path *cp)
dictionary data
Definition: stat-cpi.py:4
int db_export__sample(struct db_export *dbe, union perf_event *event, struct perf_sample *sample, struct perf_evsel *evsel, struct addr_location *al)
Definition: db-export.c:350
struct ip_callchain * callchain
Definition: event.h:211
struct map * thread__find_map(struct thread *thread, u8 cpumode, u64 addr, struct addr_location *al)
Definition: event.c:1511
int int err
Definition: 5sec.c:44
struct symbol * sym
Definition: callchain.h:140
u64 nr
Definition: event.h:157
bool show_kernel_path
Definition: symbol.h:93
static unsigned long get_offset(struct symbol *sym, struct addr_location *al)
u64 addr_offset
Definition: db-export.h:46
static int zero_flag_atom
bool db_export_mode
PyObject * evsel_handler
#define config
static int python_export_dso(struct db_export *dbe, struct dso *dso, struct machine *machine)
static int python_stop_script(void)
static void _free_command_line(const char **command_line, int num)
static PyObject * main_dict
u64 from
Definition: event.h:151
static void python_process_stat_interval(u64 tstamp)
const char * long_name
Definition: dso.h:173
static PyObject * get_sample_value_as_tuple(struct sample_read_value *value)
u64 end
Definition: symbol.h:58
u64 cycles
Definition: event.h:145
static void callchain_cursor_commit(struct callchain_cursor *cursor)
Definition: callchain.h:212
static const char * perf_reg_name(int id)
Definition: perf_regs.h:18
#define SBUILD_ID_SIZE
Definition: build-id.h:6
int db_export__init(struct db_export *dbe)
Definition: db-export.c:79
struct cpu_map * cpus
Definition: evsel.h:112
static void call_object(PyObject *handler, PyObject *args, const char *die_msg)
Definition: cpumap.h:12
#define _PyLong_FromLong(arg)
u64 phys_addr
Definition: event.h:204
static PyObject * get_field_numeric_entry(struct event_format *event, struct format_field *field, void *data)
static PyObject * main_module
u64 db_id
Definition: call-path.h:41
u64 ip
Definition: event.h:192
x86 movsq based memset() in arch/x86/lib/memset_64.S") MEMSET_FN(memset_erms
#define pr_err(fmt,...)
Definition: json.h:21
u64 db_id
Definition: evsel.h:109
struct sample_read::@79::@81 group
struct machine * machine
Definition: symbol.h:208
struct sample_read_value one
Definition: event.h:131
int db_export__branch_types(struct db_export *dbe)
Definition: db-export.c:456
struct perf_sample * sample
Definition: db-export.h:36
Definition: comm.h:11
u64 start
Definition: map.h:28
PyObject * branch_type_handler
struct branch_entry entries[0]
Definition: event.h:158
struct call_path_root * cpr
Definition: db-export.h:69
static int python_export_evsel(struct db_export *dbe, struct perf_evsel *evsel)
u64 branch_count
Definition: thread-stack.h:63
def ns(sec, nsec)
void * malloc(YYSIZE_T)
const char * key
Definition: bpf-loader.c:196
struct call_path * parent
Definition: call-path.h:38
static int python_export_sample(struct db_export *dbe, struct export_sample *es)
struct scripting_ops python_scripting_ops
unsigned long long eval_flag(const char *flag)
unsigned int scripting_max_stack
struct map * map
Definition: symbol.h:210
u8 binding
Definition: symbol.h:61
Definition: thread.h:18
#define _PyCapsule_New(arg1, arg2, arg3)
const char * name
const char * thread__comm_str(const struct thread *thread)
Definition: thread.c:258
PyObject * call_path_handler
static int get_br_mspred(struct branch_flags *flags, char *bf, int size)
struct db_export dbe
char name[0]
Definition: dso.h:197
#define _PyLong_AsLong(arg)
struct call_return_processor * crp
Definition: db-export.h:68
unsigned short priv_size
Definition: symbol.h:92
static void set_sample_read_in_dict(PyObject *dict_sample, struct perf_sample *sample, struct perf_evsel *evsel)
#define pr_debug(fmt,...)
Definition: json.h:27
u64 start
Definition: symbol.h:57
const char * name
Definition: trace-event.h:75
unsigned long long read_size(struct event_format *event, void *ptr, int size)
PyObject * comm_handler
static int python_generate_script(struct pevent *pevent, const char *outfile)
static void callchain_cursor_advance(struct callchain_cursor *cursor)
Definition: callchain.h:228
static void set_regs_in_dict(PyObject *dict, struct perf_sample *sample, struct perf_evsel *evsel)
u64 time_running
Definition: event.h:125
void db_export__exit(struct db_export *dbe)
Definition: db-export.c:91
#define _PyUnicode_FromString(arg)
struct dso * dso
Definition: map.h:45
static void pydict_set_item_string_decref(PyObject *dict, const char *key, PyObject *val)
static char * cur_field_name
struct regs_dump user_regs
Definition: event.h:213
#define _PyBytes_FromStringAndSize(arg1, arg2)
struct perf_counts_values aggr
Definition: counts.h:21
u64 comm_db_id
Definition: db-export.h:40
u64 addr_sym_db_id
Definition: db-export.h:45
struct event_format * tp_format
Definition: evsel.h:105
u64 period
Definition: event.h:198
static DECLARE_BITMAP(events_defined, TRACE_EVENT_TYPE_MAX)
u64 predicted
Definition: event.h:142
#define PATH_MAX
Definition: jevents.c:1042
u32 pid
Definition: event.h:193
pid_t tid
Definition: thread.h:25
struct call_path_root * cpr
Definition: thread-stack.h:78
u32 tid
Definition: event.h:193
static int tuple_set_u64(PyObject *t, unsigned int pos, u64 val)
static int str(yyscan_t scanner, int token)
list cpus
Definition: stat-cpi.py:7
PyObject * sample_handler
Definition: jevents.c:169
PyObject * call_return_handler
char name[0]
Definition: symbol.h:66
const char * comm__str(const struct comm *comm)
Definition: comm.c:143
union perf_mem_data_src data_src
Definition: symbol.h:203
u64 db_id
Definition: comm.h:18
struct symbol * sym
Definition: symbol.h:211
static void define_field(enum print_arg_type field_type, const char *ev_name, const char *field_name, const char *delim)
struct regs_dump intr_regs
Definition: event.h:214
Definition: dso.h:138
#define event
struct perf_counts * counts
Definition: evsel.h:98
u64 db_id
Definition: dso.h:193
struct branch_stack * branch_stack
Definition: event.h:212
struct map * map
Definition: callchain.h:139
u64 in_tx
Definition: event.h:143
u32 raw_size
Definition: event.h:202
u32 cpu
Definition: event.h:201
struct scripting_context * scripting_context
static int run_start_sub(void)
#define TRACE_EVENT_TYPE_MAX
struct thread * thread
Definition: symbol.h:209
struct thread_map * threads
Definition: evsel.h:114
PyObject * thread_handler
#define MAX_FIELDS
static int python_export_thread(struct db_export *dbe, struct thread *thread, u64 main_thread_db_id, struct machine *machine)
int map[]
Definition: cpumap.h:15
int db_export__call_return(struct db_export *dbe, struct call_return *cr)
Definition: db-export.c:490
static int python_export_branch_type(struct db_export *dbe, u32 branch_type, const char *name)
int perf_script__meminfo_scnprintf(char *out, size_t sz, struct mem_info *mem_info)
Definition: mem-events.c:297
u64 db_id
Definition: machine.h:57
#define _PyUnicode_FromStringAndSize(arg1, arg2)
#define NSEC_PER_SEC
Definition: jvmti_agent.c:101
static int get_symoff(struct symbol *sym, struct addr_location *al, bool print_off, char *bf, int size)
static void try_call_object(const char *handler_name, PyObject *args)
struct pevent * pevent
Definition: trace-event.h:97
const char * perf_evsel__name(struct perf_evsel *evsel)
Definition: evsel.c:577
void * raw_data
Definition: event.h:210
#define PRINT_FIELD(x)
u32 pid
Definition: hists_common.c:15
static int python_flush_script(void)
u64 db_id
Definition: thread.h:36
static int python_start_script(const char *script, int argc, const char **argv)
u64 call_path_id
Definition: db-export.h:47
static PyObject * python_process_brstacksym(struct perf_sample *sample, struct thread *thread)
u64 transaction
Definition: event.h:200
static void define_value(enum print_arg_type field_type, const char *ev_name, const char *field_name, const char *field_value, const char *field_str)
Definition: jevents.c:228
bool use_callchain
Definition: symbol.h:93
#define PERF_BRANCH_MASK
Definition: event.h:177
static int python_export_symbol(struct db_export *dbe, struct symbol *sym, struct dso *dso)
PyObject * symbol_handler
u8 build_id[BUILD_ID_SIZE]
Definition: dso.h:170
u32 flags
Definition: event.h:205
static int sym(yyscan_t scanner, int type, int config)
u64 time
Definition: event.h:194
u32 flags
int build_id__sprintf(const u8 *build_id, int len, char *bf)
Definition: build-id.c:89
struct perf_evsel * evsel
Definition: db-export.h:37
struct symbol * thread__find_symbol(struct thread *thread, u8 cpumode, u64 addr, struct addr_location *al)
Definition: event.c:1588
struct call_path * cp
Definition: thread-stack.h:60
char * root_dir
Definition: machine.h:45
static void python_process_general_event(struct perf_sample *sample, struct perf_evsel *evsel, struct addr_location *al)
PyObject * dso_handler
struct symbol * sym
Definition: call-path.h:39
static void define_event_symbols(struct event_format *event, const char *ev_name, struct print_arg *args)
struct sample_read read
Definition: event.h:216
static unsigned int nsecs
Definition: futex-hash.c:32
void free(void *)
static struct tables tables_global
static PyObject * get_perf_sample_dict(struct perf_sample *sample, struct perf_evsel *evsel, struct addr_location *al, PyObject *callchain)
static pid_t thread_map__pid(struct thread_map *map, int thread)
Definition: thread_map.h:46
struct thread * thread
Definition: thread-stack.h:58
pid_t pid
Definition: machine.h:41
static int python_export_machine(struct db_export *dbe, struct machine *machine)
static FILE * f
Definition: intel-pt-log.c:30
static struct perf_counts_values * perf_counts(struct perf_counts *counts, int cpu, int thread)
Definition: counts.h:27
Definition: attr.py:1
Definition: symbol.h:55
int thread__resolve_callchain(struct thread *thread, struct callchain_cursor *cursor, struct perf_evsel *evsel, struct perf_sample *sample, struct symbol **parent, struct addr_location *root_al, int max_stack)
Definition: machine.c:2308
static int python_export_comm_thread(struct db_export *dbe, u64 db_id, struct comm *comm, struct thread *thread)
static const char * get_dsoname(struct map *map)
#define SET_TABLE_HANDLER(name)
struct call_path_root * call_path_root__new(void)
Definition: call-path.c:34
static void python_process_event(union perf_event *event, struct perf_sample *sample, struct perf_evsel *evsel, struct addr_location *al)
u64 * regs
Definition: event.h:105
PyMODINIT_FUNC initperf_trace_context(void)
Definition: Context.c:96
static PyObject * python_process_callchain(struct perf_sample *sample, struct perf_evsel *evsel, struct addr_location *al)
static PyObject * tuple_new(unsigned int sz)
u64 time_enabled
Definition: event.h:124
int db_export__flush(struct db_export *dbe)
Definition: db-export.c:86
static void * symbol__priv(struct symbol *sym)
Definition: symbol.h:168
u16 namelen
Definition: symbol.h:59
PyObject * comm_thread_handler
static void process_stat(struct perf_evsel *counter, int cpu, int thread, u64 tstamp, struct perf_counts_values *count)
u8 cpumode
Definition: event.h:207
static int python_process_call_return(struct call_return *cr, void *data)
static void get_handler_name(char *str, size_t size, struct perf_evsel *evsel)
u64 to
Definition: event.h:152
const char * short_name
Definition: dso.h:172
struct perf_event_attr attr
Definition: evsel.h:93
u64 abort
Definition: event.h:144
static int tuple_set_string(PyObject *t, unsigned int pos, const char *s)
struct branch_flags flags
Definition: event.h:153
static void set_sample_datasrc_in_dict(PyObject *dict, struct perf_sample *sample)
unsigned long long raw_field_value(struct event_format *event, const char *name, void *data)
u64 mispred
Definition: event.h:141
static struct callchain_cursor_node * callchain_cursor_current(struct callchain_cursor *cursor)
Definition: callchain.h:220
static int python_export_call_return(struct db_export *dbe, struct call_return *cr)
PyObject * machine_handler
u64 ip
Definition: call-path.h:40
static void define_values(enum print_arg_type field_type, struct print_flag_sym *field, const char *ev_name, const char *field_name)