| // SPDX-License-Identifier: GPL-2.0 |
| #include <Python.h> |
| #include <structmember.h> |
| #include <inttypes.h> |
| #include <poll.h> |
| #include <linux/err.h> |
| #include "evlist.h" |
| #include "callchain.h" |
| #include "evsel.h" |
| #include "event.h" |
| #include "cpumap.h" |
| #include "print_binary.h" |
| #include "thread_map.h" |
| #include "mmap.h" |
| #include "util.h" |
| |
| #if PY_MAJOR_VERSION < 3 |
| #define _PyUnicode_FromString(arg) \ |
| PyString_FromString(arg) |
| #define _PyUnicode_AsString(arg) \ |
| PyString_AsString(arg) |
| #define _PyUnicode_FromFormat(...) \ |
| PyString_FromFormat(__VA_ARGS__) |
| #define _PyLong_FromLong(arg) \ |
| PyInt_FromLong(arg) |
| |
| #else |
| |
| #define _PyUnicode_FromString(arg) \ |
| PyUnicode_FromString(arg) |
| #define _PyUnicode_FromFormat(...) \ |
| PyUnicode_FromFormat(__VA_ARGS__) |
| #define _PyLong_FromLong(arg) \ |
| PyLong_FromLong(arg) |
| #endif |
| |
| #ifndef Py_TYPE |
| #define Py_TYPE(ob) (((PyObject*)(ob))->ob_type) |
| #endif |
| |
| /* |
| * Provide these two so that we don't have to link against callchain.c and |
| * start dragging hist.c, etc. |
| */ |
| struct callchain_param callchain_param; |
| |
| int parse_callchain_record(const char *arg __maybe_unused, |
| struct callchain_param *param __maybe_unused) |
| { |
| return 0; |
| } |
| |
| /* |
| * Support debug printing even though util/debug.c is not linked. That means |
| * implementing 'verbose' and 'eprintf'. |
| */ |
| int verbose; |
| |
| int eprintf(int level, int var, const char *fmt, ...) |
| { |
| va_list args; |
| int ret = 0; |
| |
| if (var >= level) { |
| va_start(args, fmt); |
| ret = vfprintf(stderr, fmt, args); |
| va_end(args); |
| } |
| |
| return ret; |
| } |
| |
| /* Define PyVarObject_HEAD_INIT for python 2.5 */ |
| #ifndef PyVarObject_HEAD_INIT |
| # define PyVarObject_HEAD_INIT(type, size) PyObject_HEAD_INIT(type) size, |
| #endif |
| |
| #if PY_MAJOR_VERSION < 3 |
| PyMODINIT_FUNC initperf(void); |
| #else |
| PyMODINIT_FUNC PyInit_perf(void); |
| #endif |
| |
| #define member_def(type, member, ptype, help) \ |
| { #member, ptype, \ |
| offsetof(struct pyrf_event, event) + offsetof(struct type, member), \ |
| 0, help } |
| |
| #define sample_member_def(name, member, ptype, help) \ |
| { #name, ptype, \ |
| offsetof(struct pyrf_event, sample) + offsetof(struct perf_sample, member), \ |
| 0, help } |
| |
| struct pyrf_event { |
| PyObject_HEAD |
| struct perf_evsel *evsel; |
| struct perf_sample sample; |
| union perf_event event; |
| }; |
| |
| #define sample_members \ |
| sample_member_def(sample_ip, ip, T_ULONGLONG, "event type"), \ |
| sample_member_def(sample_pid, pid, T_INT, "event pid"), \ |
| sample_member_def(sample_tid, tid, T_INT, "event tid"), \ |
| sample_member_def(sample_time, time, T_ULONGLONG, "event timestamp"), \ |
| sample_member_def(sample_addr, addr, T_ULONGLONG, "event addr"), \ |
| sample_member_def(sample_id, id, T_ULONGLONG, "event id"), \ |
| sample_member_def(sample_stream_id, stream_id, T_ULONGLONG, "event stream id"), \ |
| sample_member_def(sample_period, period, T_ULONGLONG, "event period"), \ |
| sample_member_def(sample_cpu, cpu, T_UINT, "event cpu"), |
| |
| static char pyrf_mmap_event__doc[] = PyDoc_STR("perf mmap event object."); |
| |
| static PyMemberDef pyrf_mmap_event__members[] = { |
| sample_members |
| member_def(perf_event_header, type, T_UINT, "event type"), |
| member_def(perf_event_header, misc, T_UINT, "event misc"), |
| member_def(mmap_event, pid, T_UINT, "event pid"), |
| member_def(mmap_event, tid, T_UINT, "event tid"), |
| member_def(mmap_event, start, T_ULONGLONG, "start of the map"), |
| member_def(mmap_event, len, T_ULONGLONG, "map length"), |
| member_def(mmap_event, pgoff, T_ULONGLONG, "page offset"), |
| member_def(mmap_event, filename, T_STRING_INPLACE, "backing store"), |
| { .name = NULL, }, |
| }; |
| |
| static PyObject *pyrf_mmap_event__repr(struct pyrf_event *pevent) |
| { |
| PyObject *ret; |
| char *s; |
| |
| if (asprintf(&s, "{ type: mmap, pid: %u, tid: %u, start: %#" PRIx64 ", " |
| "length: %#" PRIx64 ", offset: %#" PRIx64 ", " |
| "filename: %s }", |
| pevent->event.mmap.pid, pevent->event.mmap.tid, |
| pevent->event.mmap.start, pevent->event.mmap.len, |
| pevent->event.mmap.pgoff, pevent->event.mmap.filename) < 0) { |
| ret = PyErr_NoMemory(); |
| } else { |
| ret = _PyUnicode_FromString(s); |
| free(s); |
| } |
| return ret; |
| } |
| |
| static PyTypeObject pyrf_mmap_event__type = { |
| PyVarObject_HEAD_INIT(NULL, 0) |
| .tp_name = "perf.mmap_event", |
| .tp_basicsize = sizeof(struct pyrf_event), |
| .tp_flags = Py_TPFLAGS_DEFAULT|Py_TPFLAGS_BASETYPE, |
| .tp_doc = pyrf_mmap_event__doc, |
| .tp_members = pyrf_mmap_event__members, |
| .tp_repr = (reprfunc)pyrf_mmap_event__repr, |
| }; |
| |
| static char pyrf_task_event__doc[] = PyDoc_STR("perf task (fork/exit) event object."); |
| |
| static PyMemberDef pyrf_task_event__members[] = { |
| sample_members |
| member_def(perf_event_header, type, T_UINT, "event type"), |
| member_def(fork_event, pid, T_UINT, "event pid"), |
| member_def(fork_event, ppid, T_UINT, "event ppid"), |
| member_def(fork_event, tid, T_UINT, "event tid"), |
| member_def(fork_event, ptid, T_UINT, "event ptid"), |
| member_def(fork_event, time, T_ULONGLONG, "timestamp"), |
| { .name = NULL, }, |
| }; |
| |
| static PyObject *pyrf_task_event__repr(struct pyrf_event *pevent) |
| { |
| return _PyUnicode_FromFormat("{ type: %s, pid: %u, ppid: %u, tid: %u, " |
| "ptid: %u, time: %" PRIu64 "}", |
| pevent->event.header.type == PERF_RECORD_FORK ? "fork" : "exit", |
| pevent->event.fork.pid, |
| pevent->event.fork.ppid, |
| pevent->event.fork.tid, |
| pevent->event.fork.ptid, |
| pevent->event.fork.time); |
| } |
| |
| static PyTypeObject pyrf_task_event__type = { |
| PyVarObject_HEAD_INIT(NULL, 0) |
| .tp_name = "perf.task_event", |
| .tp_basicsize = sizeof(struct pyrf_event), |
| .tp_flags = Py_TPFLAGS_DEFAULT|Py_TPFLAGS_BASETYPE, |
| .tp_doc = pyrf_task_event__doc, |
| .tp_members = pyrf_task_event__members, |
| .tp_repr = (reprfunc)pyrf_task_event__repr, |
| }; |
| |
| static char pyrf_comm_event__doc[] = PyDoc_STR("perf comm event object."); |
| |
| static PyMemberDef pyrf_comm_event__members[] = { |
| sample_members |
| member_def(perf_event_header, type, T_UINT, "event type"), |
| member_def(comm_event, pid, T_UINT, "event pid"), |
| member_def(comm_event, tid, T_UINT, "event tid"), |
| member_def(comm_event, comm, T_STRING_INPLACE, "process name"), |
| { .name = NULL, }, |
| }; |
| |
| static PyObject *pyrf_comm_event__repr(struct pyrf_event *pevent) |
| { |
| return _PyUnicode_FromFormat("{ type: comm, pid: %u, tid: %u, comm: %s }", |
| pevent->event.comm.pid, |
| pevent->event.comm.tid, |
| pevent->event.comm.comm); |
| } |
| |
| static PyTypeObject pyrf_comm_event__type = { |
| PyVarObject_HEAD_INIT(NULL, 0) |
| .tp_name = "perf.comm_event", |
| .tp_basicsize = sizeof(struct pyrf_event), |
| .tp_flags = Py_TPFLAGS_DEFAULT|Py_TPFLAGS_BASETYPE, |
| .tp_doc = pyrf_comm_event__doc, |
| .tp_members = pyrf_comm_event__members, |
| .tp_repr = (reprfunc)pyrf_comm_event__repr, |
| }; |
| |
| static char pyrf_throttle_event__doc[] = PyDoc_STR("perf throttle event object."); |
| |
| static PyMemberDef pyrf_throttle_event__members[] = { |
| sample_members |
| member_def(perf_event_header, type, T_UINT, "event type"), |
| member_def(throttle_event, time, T_ULONGLONG, "timestamp"), |
| member_def(throttle_event, id, T_ULONGLONG, "event id"), |
| member_def(throttle_event, stream_id, T_ULONGLONG, "event stream id"), |
| { .name = NULL, }, |
| }; |
| |
| static PyObject *pyrf_throttle_event__repr(struct pyrf_event *pevent) |
| { |
| struct throttle_event *te = (struct throttle_event *)(&pevent->event.header + 1); |
| |
| return _PyUnicode_FromFormat("{ type: %sthrottle, time: %" PRIu64 ", id: %" PRIu64 |
| ", stream_id: %" PRIu64 " }", |
| pevent->event.header.type == PERF_RECORD_THROTTLE ? "" : "un", |
| te->time, te->id, te->stream_id); |
| } |
| |
| static PyTypeObject pyrf_throttle_event__type = { |
| PyVarObject_HEAD_INIT(NULL, 0) |
| .tp_name = "perf.throttle_event", |
| .tp_basicsize = sizeof(struct pyrf_event), |
| .tp_flags = Py_TPFLAGS_DEFAULT|Py_TPFLAGS_BASETYPE, |
| .tp_doc = pyrf_throttle_event__doc, |
| .tp_members = pyrf_throttle_event__members, |
| .tp_repr = (reprfunc)pyrf_throttle_event__repr, |
| }; |
| |
| static char pyrf_lost_event__doc[] = PyDoc_STR("perf lost event object."); |
| |
| static PyMemberDef pyrf_lost_event__members[] = { |
| sample_members |
| member_def(lost_event, id, T_ULONGLONG, "event id"), |
| member_def(lost_event, lost, T_ULONGLONG, "number of lost events"), |
| { .name = NULL, }, |
| }; |
| |
| static PyObject *pyrf_lost_event__repr(struct pyrf_event *pevent) |
| { |
| PyObject *ret; |
| char *s; |
| |
| if (asprintf(&s, "{ type: lost, id: %#" PRIx64 ", " |
| "lost: %#" PRIx64 " }", |
| pevent->event.lost.id, pevent->event.lost.lost) < 0) { |
| ret = PyErr_NoMemory(); |
| } else { |
| ret = _PyUnicode_FromString(s); |
| free(s); |
| } |
| return ret; |
| } |
| |
| static PyTypeObject pyrf_lost_event__type = { |
| PyVarObject_HEAD_INIT(NULL, 0) |
| .tp_name = "perf.lost_event", |
| .tp_basicsize = sizeof(struct pyrf_event), |
| .tp_flags = Py_TPFLAGS_DEFAULT|Py_TPFLAGS_BASETYPE, |
| .tp_doc = pyrf_lost_event__doc, |
| .tp_members = pyrf_lost_event__members, |
| .tp_repr = (reprfunc)pyrf_lost_event__repr, |
| }; |
| |
| static char pyrf_read_event__doc[] = PyDoc_STR("perf read event object."); |
| |
| static PyMemberDef pyrf_read_event__members[] = { |
| sample_members |
| member_def(read_event, pid, T_UINT, "event pid"), |
| member_def(read_event, tid, T_UINT, "event tid"), |
| { .name = NULL, }, |
| }; |
| |
| static PyObject *pyrf_read_event__repr(struct pyrf_event *pevent) |
| { |
| return _PyUnicode_FromFormat("{ type: read, pid: %u, tid: %u }", |
| pevent->event.read.pid, |
| pevent->event.read.tid); |
| /* |
| * FIXME: return the array of read values, |
| * making this method useful ;-) |
| */ |
| } |
| |
| static PyTypeObject pyrf_read_event__type = { |
| PyVarObject_HEAD_INIT(NULL, 0) |
| .tp_name = "perf.read_event", |
| .tp_basicsize = sizeof(struct pyrf_event), |
| .tp_flags = Py_TPFLAGS_DEFAULT|Py_TPFLAGS_BASETYPE, |
| .tp_doc = pyrf_read_event__doc, |
| .tp_members = pyrf_read_event__members, |
| .tp_repr = (reprfunc)pyrf_read_event__repr, |
| }; |
| |
| static char pyrf_sample_event__doc[] = PyDoc_STR("perf sample event object."); |
| |
| static PyMemberDef pyrf_sample_event__members[] = { |
| sample_members |
| member_def(perf_event_header, type, T_UINT, "event type"), |
| { .name = NULL, }, |
| }; |
| |
| static PyObject *pyrf_sample_event__repr(struct pyrf_event *pevent) |
| { |
| PyObject *ret; |
| char *s; |
| |
| if (asprintf(&s, "{ type: sample }") < 0) { |
| ret = PyErr_NoMemory(); |
| } else { |
| ret = _PyUnicode_FromString(s); |
| free(s); |
| } |
| return ret; |
| } |
| |
| static bool is_tracepoint(struct pyrf_event *pevent) |
| { |
| return pevent->evsel->attr.type == PERF_TYPE_TRACEPOINT; |
| } |
| |
| static PyObject* |
| tracepoint_field(struct pyrf_event *pe, struct tep_format_field *field) |
| { |
| struct tep_handle *pevent = field->event->tep; |
| void *data = pe->sample.raw_data; |
| PyObject *ret = NULL; |
| unsigned long long val; |
| unsigned int offset, len; |
| |
| if (field->flags & TEP_FIELD_IS_ARRAY) { |
| offset = field->offset; |
| len = field->size; |
| if (field->flags & TEP_FIELD_IS_DYNAMIC) { |
| val = tep_read_number(pevent, data + offset, len); |
| offset = val; |
| len = offset >> 16; |
| offset &= 0xffff; |
| } |
| if (field->flags & TEP_FIELD_IS_STRING && |
| is_printable_array(data + offset, len)) { |
| ret = _PyUnicode_FromString((char *)data + offset); |
| } else { |
| ret = PyByteArray_FromStringAndSize((const char *) data + offset, len); |
| field->flags &= ~TEP_FIELD_IS_STRING; |
| } |
| } else { |
| val = tep_read_number(pevent, data + field->offset, |
| field->size); |
| if (field->flags & TEP_FIELD_IS_POINTER) |
| ret = PyLong_FromUnsignedLong((unsigned long) val); |
| else if (field->flags & TEP_FIELD_IS_SIGNED) |
| ret = PyLong_FromLong((long) val); |
| else |
| ret = PyLong_FromUnsignedLong((unsigned long) val); |
| } |
| |
| return ret; |
| } |
| |
| static PyObject* |
| get_tracepoint_field(struct pyrf_event *pevent, PyObject *attr_name) |
| { |
| const char *str = _PyUnicode_AsString(PyObject_Str(attr_name)); |
| struct perf_evsel *evsel = pevent->evsel; |
| struct tep_format_field *field; |
| |
| if (!evsel->tp_format) { |
| struct tep_event *tp_format; |
| |
| tp_format = trace_event__tp_format_id(evsel->attr.config); |
| if (!tp_format) |
| return NULL; |
| |
| evsel->tp_format = tp_format; |
| } |
| |
| field = tep_find_any_field(evsel->tp_format, str); |
| if (!field) |
| return NULL; |
| |
| return tracepoint_field(pevent, field); |
| } |
| |
| static PyObject* |
| pyrf_sample_event__getattro(struct pyrf_event *pevent, PyObject *attr_name) |
| { |
| PyObject *obj = NULL; |
| |
| if (is_tracepoint(pevent)) |
| obj = get_tracepoint_field(pevent, attr_name); |
| |
| return obj ?: PyObject_GenericGetAttr((PyObject *) pevent, attr_name); |
| } |
| |
| static PyTypeObject pyrf_sample_event__type = { |
| PyVarObject_HEAD_INIT(NULL, 0) |
| .tp_name = "perf.sample_event", |
| .tp_basicsize = sizeof(struct pyrf_event), |
| .tp_flags = Py_TPFLAGS_DEFAULT|Py_TPFLAGS_BASETYPE, |
| .tp_doc = pyrf_sample_event__doc, |
| .tp_members = pyrf_sample_event__members, |
| .tp_repr = (reprfunc)pyrf_sample_event__repr, |
| .tp_getattro = (getattrofunc) pyrf_sample_event__getattro, |
| }; |
| |
| static char pyrf_context_switch_event__doc[] = PyDoc_STR("perf context_switch event object."); |
| |
| static PyMemberDef pyrf_context_switch_event__members[] = { |
| sample_members |
| member_def(perf_event_header, type, T_UINT, "event type"), |
| member_def(context_switch_event, next_prev_pid, T_UINT, "next/prev pid"), |
| member_def(context_switch_event, next_prev_tid, T_UINT, "next/prev tid"), |
| { .name = NULL, }, |
| }; |
| |
| static PyObject *pyrf_context_switch_event__repr(struct pyrf_event *pevent) |
| { |
| PyObject *ret; |
| char *s; |
| |
| if (asprintf(&s, "{ type: context_switch, next_prev_pid: %u, next_prev_tid: %u, switch_out: %u }", |
| pevent->event.context_switch.next_prev_pid, |
| pevent->event.context_switch.next_prev_tid, |
| !!(pevent->event.header.misc & PERF_RECORD_MISC_SWITCH_OUT)) < 0) { |
| ret = PyErr_NoMemory(); |
| } else { |
| ret = _PyUnicode_FromString(s); |
| free(s); |
| } |
| return ret; |
| } |
| |
| static PyTypeObject pyrf_context_switch_event__type = { |
| PyVarObject_HEAD_INIT(NULL, 0) |
| .tp_name = "perf.context_switch_event", |
| .tp_basicsize = sizeof(struct pyrf_event), |
| .tp_flags = Py_TPFLAGS_DEFAULT|Py_TPFLAGS_BASETYPE, |
| .tp_doc = pyrf_context_switch_event__doc, |
| .tp_members = pyrf_context_switch_event__members, |
| .tp_repr = (reprfunc)pyrf_context_switch_event__repr, |
| }; |
| |
| static int pyrf_event__setup_types(void) |
| { |
| int err; |
| pyrf_mmap_event__type.tp_new = |
| pyrf_task_event__type.tp_new = |
| pyrf_comm_event__type.tp_new = |
| pyrf_lost_event__type.tp_new = |
| pyrf_read_event__type.tp_new = |
| pyrf_sample_event__type.tp_new = |
| pyrf_context_switch_event__type.tp_new = |
| pyrf_throttle_event__type.tp_new = PyType_GenericNew; |
| err = PyType_Ready(&pyrf_mmap_event__type); |
| if (err < 0) |
| goto out; |
| err = PyType_Ready(&pyrf_lost_event__type); |
| if (err < 0) |
| goto out; |
| err = PyType_Ready(&pyrf_task_event__type); |
| if (err < 0) |
| goto out; |
| err = PyType_Ready(&pyrf_comm_event__type); |
| if (err < 0) |
| goto out; |
| err = PyType_Ready(&pyrf_throttle_event__type); |
| if (err < 0) |
| goto out; |
| err = PyType_Ready(&pyrf_read_event__type); |
| if (err < 0) |
| goto out; |
| err = PyType_Ready(&pyrf_sample_event__type); |
| if (err < 0) |
| goto out; |
| err = PyType_Ready(&pyrf_context_switch_event__type); |
| if (err < 0) |
| goto out; |
| out: |
| return err; |
| } |
| |
| static PyTypeObject *pyrf_event__type[] = { |
| [PERF_RECORD_MMAP] = &pyrf_mmap_event__type, |
| [PERF_RECORD_LOST] = &pyrf_lost_event__type, |
| [PERF_RECORD_COMM] = &pyrf_comm_event__type, |
| [PERF_RECORD_EXIT] = &pyrf_task_event__type, |
| [PERF_RECORD_THROTTLE] = &pyrf_throttle_event__type, |
| [PERF_RECORD_UNTHROTTLE] = &pyrf_throttle_event__type, |
| [PERF_RECORD_FORK] = &pyrf_task_event__type, |
| [PERF_RECORD_READ] = &pyrf_read_event__type, |
| [PERF_RECORD_SAMPLE] = &pyrf_sample_event__type, |
| [PERF_RECORD_SWITCH] = &pyrf_context_switch_event__type, |
| [PERF_RECORD_SWITCH_CPU_WIDE] = &pyrf_context_switch_event__type, |
| }; |
| |
| static PyObject *pyrf_event__new(union perf_event *event) |
| { |
| struct pyrf_event *pevent; |
| PyTypeObject *ptype; |
| |
| if ((event->header.type < PERF_RECORD_MMAP || |
| event->header.type > PERF_RECORD_SAMPLE) && |
| !(event->header.type == PERF_RECORD_SWITCH || |
| event->header.type == PERF_RECORD_SWITCH_CPU_WIDE)) |
| return NULL; |
| |
| ptype = pyrf_event__type[event->header.type]; |
| pevent = PyObject_New(struct pyrf_event, ptype); |
| if (pevent != NULL) |
| memcpy(&pevent->event, event, event->header.size); |
| return (PyObject *)pevent; |
| } |
| |
| struct pyrf_cpu_map { |
| PyObject_HEAD |
| |
| struct cpu_map *cpus; |
| }; |
| |
| static int pyrf_cpu_map__init(struct pyrf_cpu_map *pcpus, |
| PyObject *args, PyObject *kwargs) |
| { |
| static char *kwlist[] = { "cpustr", NULL }; |
| char *cpustr = NULL; |
| |
| if (!PyArg_ParseTupleAndKeywords(args, kwargs, "|s", |
| kwlist, &cpustr)) |
| return -1; |
| |
| pcpus->cpus = cpu_map__new(cpustr); |
| if (pcpus->cpus == NULL) |
| return -1; |
| return 0; |
| } |
| |
| static void pyrf_cpu_map__delete(struct pyrf_cpu_map *pcpus) |
| { |
| cpu_map__put(pcpus->cpus); |
| Py_TYPE(pcpus)->tp_free((PyObject*)pcpus); |
| } |
| |
| static Py_ssize_t pyrf_cpu_map__length(PyObject *obj) |
| { |
| struct pyrf_cpu_map *pcpus = (void *)obj; |
| |
| return pcpus->cpus->nr; |
| } |
| |
| static PyObject *pyrf_cpu_map__item(PyObject *obj, Py_ssize_t i) |
| { |
| struct pyrf_cpu_map *pcpus = (void *)obj; |
| |
| if (i >= pcpus->cpus->nr) |
| return NULL; |
| |
| return Py_BuildValue("i", pcpus->cpus->map[i]); |
| } |
| |
| static PySequenceMethods pyrf_cpu_map__sequence_methods = { |
| .sq_length = pyrf_cpu_map__length, |
| .sq_item = pyrf_cpu_map__item, |
| }; |
| |
| static char pyrf_cpu_map__doc[] = PyDoc_STR("cpu map object."); |
| |
| static PyTypeObject pyrf_cpu_map__type = { |
| PyVarObject_HEAD_INIT(NULL, 0) |
| .tp_name = "perf.cpu_map", |
| .tp_basicsize = sizeof(struct pyrf_cpu_map), |
| .tp_dealloc = (destructor)pyrf_cpu_map__delete, |
| .tp_flags = Py_TPFLAGS_DEFAULT|Py_TPFLAGS_BASETYPE, |
| .tp_doc = pyrf_cpu_map__doc, |
| .tp_as_sequence = &pyrf_cpu_map__sequence_methods, |
| .tp_init = (initproc)pyrf_cpu_map__init, |
| }; |
| |
| static int pyrf_cpu_map__setup_types(void) |
| { |
| pyrf_cpu_map__type.tp_new = PyType_GenericNew; |
| return PyType_Ready(&pyrf_cpu_map__type); |
| } |
| |
| struct pyrf_thread_map { |
| PyObject_HEAD |
| |
| struct thread_map *threads; |
| }; |
| |
| static int pyrf_thread_map__init(struct pyrf_thread_map *pthreads, |
| PyObject *args, PyObject *kwargs) |
| { |
| static char *kwlist[] = { "pid", "tid", "uid", NULL }; |
| int pid = -1, tid = -1, uid = UINT_MAX; |
| |
| if (!PyArg_ParseTupleAndKeywords(args, kwargs, "|iii", |
| kwlist, &pid, &tid, &uid)) |
| return -1; |
| |
| pthreads->threads = thread_map__new(pid, tid, uid); |
| if (pthreads->threads == NULL) |
| return -1; |
| return 0; |
| } |
| |
| static void pyrf_thread_map__delete(struct pyrf_thread_map *pthreads) |
| { |
| thread_map__put(pthreads->threads); |
| Py_TYPE(pthreads)->tp_free((PyObject*)pthreads); |
| } |
| |
| static Py_ssize_t pyrf_thread_map__length(PyObject *obj) |
| { |
| struct pyrf_thread_map *pthreads = (void *)obj; |
| |
| return pthreads->threads->nr; |
| } |
| |
| static PyObject *pyrf_thread_map__item(PyObject *obj, Py_ssize_t i) |
| { |
| struct pyrf_thread_map *pthreads = (void *)obj; |
| |
| if (i >= pthreads->threads->nr) |
| return NULL; |
| |
| return Py_BuildValue("i", pthreads->threads->map[i]); |
| } |
| |
| static PySequenceMethods pyrf_thread_map__sequence_methods = { |
| .sq_length = pyrf_thread_map__length, |
| .sq_item = pyrf_thread_map__item, |
| }; |
| |
| static char pyrf_thread_map__doc[] = PyDoc_STR("thread map object."); |
| |
| static PyTypeObject pyrf_thread_map__type = { |
| PyVarObject_HEAD_INIT(NULL, 0) |
| .tp_name = "perf.thread_map", |
| .tp_basicsize = sizeof(struct pyrf_thread_map), |
| .tp_dealloc = (destructor)pyrf_thread_map__delete, |
| .tp_flags = Py_TPFLAGS_DEFAULT|Py_TPFLAGS_BASETYPE, |
| .tp_doc = pyrf_thread_map__doc, |
| .tp_as_sequence = &pyrf_thread_map__sequence_methods, |
| .tp_init = (initproc)pyrf_thread_map__init, |
| }; |
| |
| static int pyrf_thread_map__setup_types(void) |
| { |
| pyrf_thread_map__type.tp_new = PyType_GenericNew; |
| return PyType_Ready(&pyrf_thread_map__type); |
| } |
| |
| struct pyrf_evsel { |
| PyObject_HEAD |
| |
| struct perf_evsel evsel; |
| }; |
| |
| static int pyrf_evsel__init(struct pyrf_evsel *pevsel, |
| PyObject *args, PyObject *kwargs) |
| { |
| struct perf_event_attr attr = { |
| .type = PERF_TYPE_HARDWARE, |
| .config = PERF_COUNT_HW_CPU_CYCLES, |
| .sample_type = PERF_SAMPLE_PERIOD | PERF_SAMPLE_TID, |
| }; |
| static char *kwlist[] = { |
| "type", |
| "config", |
| "sample_freq", |
| "sample_period", |
| "sample_type", |
| "read_format", |
| "disabled", |
| "inherit", |
| "pinned", |
| "exclusive", |
| "exclude_user", |
| "exclude_kernel", |
| "exclude_hv", |
| "exclude_idle", |
| "mmap", |
| "context_switch", |
| "comm", |
| "freq", |
| "inherit_stat", |
| "enable_on_exec", |
| "task", |
| "watermark", |
| "precise_ip", |
| "mmap_data", |
| "sample_id_all", |
| "wakeup_events", |
| "bp_type", |
| "bp_addr", |
| "bp_len", |
| NULL |
| }; |
| u64 sample_period = 0; |
| u32 disabled = 0, |
| inherit = 0, |
| pinned = 0, |
| exclusive = 0, |
| exclude_user = 0, |
| exclude_kernel = 0, |
| exclude_hv = 0, |
| exclude_idle = 0, |
| mmap = 0, |
| context_switch = 0, |
| comm = 0, |
| freq = 1, |
| inherit_stat = 0, |
| enable_on_exec = 0, |
| task = 0, |
| watermark = 0, |
| precise_ip = 0, |
| mmap_data = 0, |
| sample_id_all = 1; |
| int idx = 0; |
| |
| if (!PyArg_ParseTupleAndKeywords(args, kwargs, |
| "|iKiKKiiiiiiiiiiiiiiiiiiiiiiKK", kwlist, |
| &attr.type, &attr.config, &attr.sample_freq, |
| &sample_period, &attr.sample_type, |
| &attr.read_format, &disabled, &inherit, |
| &pinned, &exclusive, &exclude_user, |
| &exclude_kernel, &exclude_hv, &exclude_idle, |
| &mmap, &context_switch, &comm, &freq, &inherit_stat, |
| &enable_on_exec, &task, &watermark, |
| &precise_ip, &mmap_data, &sample_id_all, |
| &attr.wakeup_events, &attr.bp_type, |
| &attr.bp_addr, &attr.bp_len, &idx)) |
| return -1; |
| |
| /* union... */ |
| if (sample_period != 0) { |
| if (attr.sample_freq != 0) |
| return -1; /* FIXME: throw right exception */ |
| attr.sample_period = sample_period; |
| } |
| |
| /* Bitfields */ |
| attr.disabled = disabled; |
| attr.inherit = inherit; |
| attr.pinned = pinned; |
| attr.exclusive = exclusive; |
| attr.exclude_user = exclude_user; |
| attr.exclude_kernel = exclude_kernel; |
| attr.exclude_hv = exclude_hv; |
| attr.exclude_idle = exclude_idle; |
| attr.mmap = mmap; |
| attr.context_switch = context_switch; |
| attr.comm = comm; |
| attr.freq = freq; |
| attr.inherit_stat = inherit_stat; |
| attr.enable_on_exec = enable_on_exec; |
| attr.task = task; |
| attr.watermark = watermark; |
| attr.precise_ip = precise_ip; |
| attr.mmap_data = mmap_data; |
| attr.sample_id_all = sample_id_all; |
| attr.size = sizeof(attr); |
| |
| perf_evsel__init(&pevsel->evsel, &attr, idx); |
| return 0; |
| } |
| |
| static void pyrf_evsel__delete(struct pyrf_evsel *pevsel) |
| { |
| perf_evsel__exit(&pevsel->evsel); |
| Py_TYPE(pevsel)->tp_free((PyObject*)pevsel); |
| } |
| |
| static PyObject *pyrf_evsel__open(struct pyrf_evsel *pevsel, |
| PyObject *args, PyObject *kwargs) |
| { |
| struct perf_evsel *evsel = &pevsel->evsel; |
| struct cpu_map *cpus = NULL; |
| struct thread_map *threads = NULL; |
| PyObject *pcpus = NULL, *pthreads = NULL; |
| int group = 0, inherit = 0; |
| static char *kwlist[] = { "cpus", "threads", "group", "inherit", NULL }; |
| |
| if (!PyArg_ParseTupleAndKeywords(args, kwargs, "|OOii", kwlist, |
| &pcpus, &pthreads, &group, &inherit)) |
| return NULL; |
| |
| if (pthreads != NULL) |
| threads = ((struct pyrf_thread_map *)pthreads)->threads; |
| |
| if (pcpus != NULL) |
| cpus = ((struct pyrf_cpu_map *)pcpus)->cpus; |
| |
| evsel->attr.inherit = inherit; |
| /* |
| * This will group just the fds for this single evsel, to group |
| * multiple events, use evlist.open(). |
| */ |
| if (perf_evsel__open(evsel, cpus, threads) < 0) { |
| PyErr_SetFromErrno(PyExc_OSError); |
| return NULL; |
| } |
| |
| Py_INCREF(Py_None); |
| return Py_None; |
| } |
| |
| static PyMethodDef pyrf_evsel__methods[] = { |
| { |
| .ml_name = "open", |
| .ml_meth = (PyCFunction)pyrf_evsel__open, |
| .ml_flags = METH_VARARGS | METH_KEYWORDS, |
| .ml_doc = PyDoc_STR("open the event selector file descriptor table.") |
| }, |
| { .ml_name = NULL, } |
| }; |
| |
| static char pyrf_evsel__doc[] = PyDoc_STR("perf event selector list object."); |
| |
| static PyTypeObject pyrf_evsel__type = { |
| PyVarObject_HEAD_INIT(NULL, 0) |
| .tp_name = "perf.evsel", |
| .tp_basicsize = sizeof(struct pyrf_evsel), |
| .tp_dealloc = (destructor)pyrf_evsel__delete, |
| .tp_flags = Py_TPFLAGS_DEFAULT|Py_TPFLAGS_BASETYPE, |
| .tp_doc = pyrf_evsel__doc, |
| .tp_methods = pyrf_evsel__methods, |
| .tp_init = (initproc)pyrf_evsel__init, |
| }; |
| |
| static int pyrf_evsel__setup_types(void) |
| { |
| pyrf_evsel__type.tp_new = PyType_GenericNew; |
| return PyType_Ready(&pyrf_evsel__type); |
| } |
| |
| struct pyrf_evlist { |
| PyObject_HEAD |
| |
| struct perf_evlist evlist; |
| }; |
| |
| static int pyrf_evlist__init(struct pyrf_evlist *pevlist, |
| PyObject *args, PyObject *kwargs __maybe_unused) |
| { |
| PyObject *pcpus = NULL, *pthreads = NULL; |
| struct cpu_map *cpus; |
| struct thread_map *threads; |
| |
| if (!PyArg_ParseTuple(args, "OO", &pcpus, &pthreads)) |
| return -1; |
| |
| threads = ((struct pyrf_thread_map *)pthreads)->threads; |
| cpus = ((struct pyrf_cpu_map *)pcpus)->cpus; |
| perf_evlist__init(&pevlist->evlist, cpus, threads); |
| return 0; |
| } |
| |
| static void pyrf_evlist__delete(struct pyrf_evlist *pevlist) |
| { |
| perf_evlist__exit(&pevlist->evlist); |
| Py_TYPE(pevlist)->tp_free((PyObject*)pevlist); |
| } |
| |
| static PyObject *pyrf_evlist__mmap(struct pyrf_evlist *pevlist, |
| PyObject *args, PyObject *kwargs) |
| { |
| struct perf_evlist *evlist = &pevlist->evlist; |
| static char *kwlist[] = { "pages", "overwrite", NULL }; |
| int pages = 128, overwrite = false; |
| |
| if (!PyArg_ParseTupleAndKeywords(args, kwargs, "|ii", kwlist, |
| &pages, &overwrite)) |
| return NULL; |
| |
| if (perf_evlist__mmap(evlist, pages) < 0) { |
| PyErr_SetFromErrno(PyExc_OSError); |
| return NULL; |
| } |
| |
| Py_INCREF(Py_None); |
| return Py_None; |
| } |
| |
| static PyObject *pyrf_evlist__poll(struct pyrf_evlist *pevlist, |
| PyObject *args, PyObject *kwargs) |
| { |
| struct perf_evlist *evlist = &pevlist->evlist; |
| static char *kwlist[] = { "timeout", NULL }; |
| int timeout = -1, n; |
| |
| if (!PyArg_ParseTupleAndKeywords(args, kwargs, "|i", kwlist, &timeout)) |
| return NULL; |
| |
| n = perf_evlist__poll(evlist, timeout); |
| if (n < 0) { |
| PyErr_SetFromErrno(PyExc_OSError); |
| return NULL; |
| } |
| |
| return Py_BuildValue("i", n); |
| } |
| |
| static PyObject *pyrf_evlist__get_pollfd(struct pyrf_evlist *pevlist, |
| PyObject *args __maybe_unused, |
| PyObject *kwargs __maybe_unused) |
| { |
| struct perf_evlist *evlist = &pevlist->evlist; |
| PyObject *list = PyList_New(0); |
| int i; |
| |
| for (i = 0; i < evlist->pollfd.nr; ++i) { |
| PyObject *file; |
| #if PY_MAJOR_VERSION < 3 |
| FILE *fp = fdopen(evlist->pollfd.entries[i].fd, "r"); |
| |
| if (fp == NULL) |
| goto free_list; |
| |
| file = PyFile_FromFile(fp, "perf", "r", NULL); |
| #else |
| file = PyFile_FromFd(evlist->pollfd.entries[i].fd, "perf", "r", -1, |
| NULL, NULL, NULL, 0); |
| #endif |
| if (file == NULL) |
| goto free_list; |
| |
| if (PyList_Append(list, file) != 0) { |
| Py_DECREF(file); |
| goto free_list; |
| } |
| |
| Py_DECREF(file); |
| } |
| |
| return list; |
| free_list: |
| return PyErr_NoMemory(); |
| } |
| |
| |
| static PyObject *pyrf_evlist__add(struct pyrf_evlist *pevlist, |
| PyObject *args, |
| PyObject *kwargs __maybe_unused) |
| { |
| struct perf_evlist *evlist = &pevlist->evlist; |
| PyObject *pevsel; |
| struct perf_evsel *evsel; |
| |
| if (!PyArg_ParseTuple(args, "O", &pevsel)) |
| return NULL; |
| |
| Py_INCREF(pevsel); |
| evsel = &((struct pyrf_evsel *)pevsel)->evsel; |
| evsel->idx = evlist->nr_entries; |
| perf_evlist__add(evlist, evsel); |
| |
| return Py_BuildValue("i", evlist->nr_entries); |
| } |
| |
| static struct perf_mmap *get_md(struct perf_evlist *evlist, int cpu) |
| { |
| int i; |
| |
| for (i = 0; i < evlist->nr_mmaps; i++) { |
| struct perf_mmap *md = &evlist->mmap[i]; |
| |
| if (md->cpu == cpu) |
| return md; |
| } |
| |
| return NULL; |
| } |
| |
| static PyObject *pyrf_evlist__read_on_cpu(struct pyrf_evlist *pevlist, |
| PyObject *args, PyObject *kwargs) |
| { |
| struct perf_evlist *evlist = &pevlist->evlist; |
| union perf_event *event; |
| int sample_id_all = 1, cpu; |
| static char *kwlist[] = { "cpu", "sample_id_all", NULL }; |
| struct perf_mmap *md; |
| int err; |
| |
| if (!PyArg_ParseTupleAndKeywords(args, kwargs, "i|i", kwlist, |
| &cpu, &sample_id_all)) |
| return NULL; |
| |
| md = get_md(evlist, cpu); |
| if (!md) |
| return NULL; |
| |
| if (perf_mmap__read_init(md) < 0) |
| goto end; |
| |
| event = perf_mmap__read_event(md); |
| if (event != NULL) { |
| PyObject *pyevent = pyrf_event__new(event); |
| struct pyrf_event *pevent = (struct pyrf_event *)pyevent; |
| struct perf_evsel *evsel; |
| |
| if (pyevent == NULL) |
| return PyErr_NoMemory(); |
| |
| evsel = perf_evlist__event2evsel(evlist, event); |
| if (!evsel) { |
| Py_INCREF(Py_None); |
| return Py_None; |
| } |
| |
| pevent->evsel = evsel; |
| |
| err = perf_evsel__parse_sample(evsel, event, &pevent->sample); |
| |
| /* Consume the even only after we parsed it out. */ |
| perf_mmap__consume(md); |
| |
| if (err) |
| return PyErr_Format(PyExc_OSError, |
| "perf: can't parse sample, err=%d", err); |
| return pyevent; |
| } |
| end: |
| Py_INCREF(Py_None); |
| return Py_None; |
| } |
| |
| static PyObject *pyrf_evlist__open(struct pyrf_evlist *pevlist, |
| PyObject *args, PyObject *kwargs) |
| { |
| struct perf_evlist *evlist = &pevlist->evlist; |
| int group = 0; |
| static char *kwlist[] = { "group", NULL }; |
| |
| if (!PyArg_ParseTupleAndKeywords(args, kwargs, "|OOii", kwlist, &group)) |
| return NULL; |
| |
| if (group) |
| perf_evlist__set_leader(evlist); |
| |
| if (perf_evlist__open(evlist) < 0) { |
| PyErr_SetFromErrno(PyExc_OSError); |
| return NULL; |
| } |
| |
| Py_INCREF(Py_None); |
| return Py_None; |
| } |
| |
| static PyMethodDef pyrf_evlist__methods[] = { |
| { |
| .ml_name = "mmap", |
| .ml_meth = (PyCFunction)pyrf_evlist__mmap, |
| .ml_flags = METH_VARARGS | METH_KEYWORDS, |
| .ml_doc = PyDoc_STR("mmap the file descriptor table.") |
| }, |
| { |
| .ml_name = "open", |
| .ml_meth = (PyCFunction)pyrf_evlist__open, |
| .ml_flags = METH_VARARGS | METH_KEYWORDS, |
| .ml_doc = PyDoc_STR("open the file descriptors.") |
| }, |
| { |
| .ml_name = "poll", |
| .ml_meth = (PyCFunction)pyrf_evlist__poll, |
| .ml_flags = METH_VARARGS | METH_KEYWORDS, |
| .ml_doc = PyDoc_STR("poll the file descriptor table.") |
| }, |
| { |
| .ml_name = "get_pollfd", |
| .ml_meth = (PyCFunction)pyrf_evlist__get_pollfd, |
| .ml_flags = METH_VARARGS | METH_KEYWORDS, |
| .ml_doc = PyDoc_STR("get the poll file descriptor table.") |
| }, |
| { |
| .ml_name = "add", |
| .ml_meth = (PyCFunction)pyrf_evlist__add, |
| .ml_flags = METH_VARARGS | METH_KEYWORDS, |
| .ml_doc = PyDoc_STR("adds an event selector to the list.") |
| }, |
| { |
| .ml_name = "read_on_cpu", |
| .ml_meth = (PyCFunction)pyrf_evlist__read_on_cpu, |
| .ml_flags = METH_VARARGS | METH_KEYWORDS, |
| .ml_doc = PyDoc_STR("reads an event.") |
| }, |
| { .ml_name = NULL, } |
| }; |
| |
| static Py_ssize_t pyrf_evlist__length(PyObject *obj) |
| { |
| struct pyrf_evlist *pevlist = (void *)obj; |
| |
| return pevlist->evlist.nr_entries; |
| } |
| |
| static PyObject *pyrf_evlist__item(PyObject *obj, Py_ssize_t i) |
| { |
| struct pyrf_evlist *pevlist = (void *)obj; |
| struct perf_evsel *pos; |
| |
| if (i >= pevlist->evlist.nr_entries) |
| return NULL; |
| |
| evlist__for_each_entry(&pevlist->evlist, pos) { |
| if (i-- == 0) |
| break; |
| } |
| |
| return Py_BuildValue("O", container_of(pos, struct pyrf_evsel, evsel)); |
| } |
| |
| static PySequenceMethods pyrf_evlist__sequence_methods = { |
| .sq_length = pyrf_evlist__length, |
| .sq_item = pyrf_evlist__item, |
| }; |
| |
| static char pyrf_evlist__doc[] = PyDoc_STR("perf event selector list object."); |
| |
| static PyTypeObject pyrf_evlist__type = { |
| PyVarObject_HEAD_INIT(NULL, 0) |
| .tp_name = "perf.evlist", |
| .tp_basicsize = sizeof(struct pyrf_evlist), |
| .tp_dealloc = (destructor)pyrf_evlist__delete, |
| .tp_flags = Py_TPFLAGS_DEFAULT|Py_TPFLAGS_BASETYPE, |
| .tp_as_sequence = &pyrf_evlist__sequence_methods, |
| .tp_doc = pyrf_evlist__doc, |
| .tp_methods = pyrf_evlist__methods, |
| .tp_init = (initproc)pyrf_evlist__init, |
| }; |
| |
| static int pyrf_evlist__setup_types(void) |
| { |
| pyrf_evlist__type.tp_new = PyType_GenericNew; |
| return PyType_Ready(&pyrf_evlist__type); |
| } |
| |
| #define PERF_CONST(name) { #name, PERF_##name } |
| |
| static struct { |
| const char *name; |
| int value; |
| } perf__constants[] = { |
| PERF_CONST(TYPE_HARDWARE), |
| PERF_CONST(TYPE_SOFTWARE), |
| PERF_CONST(TYPE_TRACEPOINT), |
| PERF_CONST(TYPE_HW_CACHE), |
| PERF_CONST(TYPE_RAW), |
| PERF_CONST(TYPE_BREAKPOINT), |
| |
| PERF_CONST(COUNT_HW_CPU_CYCLES), |
| PERF_CONST(COUNT_HW_INSTRUCTIONS), |
| PERF_CONST(COUNT_HW_CACHE_REFERENCES), |
| PERF_CONST(COUNT_HW_CACHE_MISSES), |
| PERF_CONST(COUNT_HW_BRANCH_INSTRUCTIONS), |
| PERF_CONST(COUNT_HW_BRANCH_MISSES), |
| PERF_CONST(COUNT_HW_BUS_CYCLES), |
| PERF_CONST(COUNT_HW_CACHE_L1D), |
| PERF_CONST(COUNT_HW_CACHE_L1I), |
| PERF_CONST(COUNT_HW_CACHE_LL), |
| PERF_CONST(COUNT_HW_CACHE_DTLB), |
| PERF_CONST(COUNT_HW_CACHE_ITLB), |
| PERF_CONST(COUNT_HW_CACHE_BPU), |
| PERF_CONST(COUNT_HW_CACHE_OP_READ), |
| PERF_CONST(COUNT_HW_CACHE_OP_WRITE), |
| PERF_CONST(COUNT_HW_CACHE_OP_PREFETCH), |
| PERF_CONST(COUNT_HW_CACHE_RESULT_ACCESS), |
| PERF_CONST(COUNT_HW_CACHE_RESULT_MISS), |
| |
| PERF_CONST(COUNT_HW_STALLED_CYCLES_FRONTEND), |
| PERF_CONST(COUNT_HW_STALLED_CYCLES_BACKEND), |
| |
| PERF_CONST(COUNT_SW_CPU_CLOCK), |
| PERF_CONST(COUNT_SW_TASK_CLOCK), |
| PERF_CONST(COUNT_SW_PAGE_FAULTS), |
| PERF_CONST(COUNT_SW_CONTEXT_SWITCHES), |
| PERF_CONST(COUNT_SW_CPU_MIGRATIONS), |
| PERF_CONST(COUNT_SW_PAGE_FAULTS_MIN), |
| PERF_CONST(COUNT_SW_PAGE_FAULTS_MAJ), |
| PERF_CONST(COUNT_SW_ALIGNMENT_FAULTS), |
| PERF_CONST(COUNT_SW_EMULATION_FAULTS), |
| PERF_CONST(COUNT_SW_DUMMY), |
| |
| PERF_CONST(SAMPLE_IP), |
| PERF_CONST(SAMPLE_TID), |
| PERF_CONST(SAMPLE_TIME), |
| PERF_CONST(SAMPLE_ADDR), |
| PERF_CONST(SAMPLE_READ), |
| PERF_CONST(SAMPLE_CALLCHAIN), |
| PERF_CONST(SAMPLE_ID), |
| PERF_CONST(SAMPLE_CPU), |
| PERF_CONST(SAMPLE_PERIOD), |
| PERF_CONST(SAMPLE_STREAM_ID), |
| PERF_CONST(SAMPLE_RAW), |
| |
| PERF_CONST(FORMAT_TOTAL_TIME_ENABLED), |
| PERF_CONST(FORMAT_TOTAL_TIME_RUNNING), |
| PERF_CONST(FORMAT_ID), |
| PERF_CONST(FORMAT_GROUP), |
| |
| PERF_CONST(RECORD_MMAP), |
| PERF_CONST(RECORD_LOST), |
| PERF_CONST(RECORD_COMM), |
| PERF_CONST(RECORD_EXIT), |
| PERF_CONST(RECORD_THROTTLE), |
| PERF_CONST(RECORD_UNTHROTTLE), |
| PERF_CONST(RECORD_FORK), |
| PERF_CONST(RECORD_READ), |
| PERF_CONST(RECORD_SAMPLE), |
| PERF_CONST(RECORD_MMAP2), |
| PERF_CONST(RECORD_AUX), |
| PERF_CONST(RECORD_ITRACE_START), |
| PERF_CONST(RECORD_LOST_SAMPLES), |
| PERF_CONST(RECORD_SWITCH), |
| PERF_CONST(RECORD_SWITCH_CPU_WIDE), |
| |
| PERF_CONST(RECORD_MISC_SWITCH_OUT), |
| { .name = NULL, }, |
| }; |
| |
| static PyObject *pyrf__tracepoint(struct pyrf_evsel *pevsel, |
| PyObject *args, PyObject *kwargs) |
| { |
| struct tep_event *tp_format; |
| static char *kwlist[] = { "sys", "name", NULL }; |
| char *sys = NULL; |
| char *name = NULL; |
| |
| if (!PyArg_ParseTupleAndKeywords(args, kwargs, "|ss", kwlist, |
| &sys, &name)) |
| return NULL; |
| |
| tp_format = trace_event__tp_format(sys, name); |
| if (IS_ERR(tp_format)) |
| return _PyLong_FromLong(-1); |
| |
| return _PyLong_FromLong(tp_format->id); |
| } |
| |
| static PyMethodDef perf__methods[] = { |
| { |
| .ml_name = "tracepoint", |
| .ml_meth = (PyCFunction) pyrf__tracepoint, |
| .ml_flags = METH_VARARGS | METH_KEYWORDS, |
| .ml_doc = PyDoc_STR("Get tracepoint config.") |
| }, |
| { .ml_name = NULL, } |
| }; |
| |
| #if PY_MAJOR_VERSION < 3 |
| PyMODINIT_FUNC initperf(void) |
| #else |
| PyMODINIT_FUNC PyInit_perf(void) |
| #endif |
| { |
| PyObject *obj; |
| int i; |
| PyObject *dict; |
| #if PY_MAJOR_VERSION < 3 |
| PyObject *module = Py_InitModule("perf", perf__methods); |
| #else |
| static struct PyModuleDef moduledef = { |
| PyModuleDef_HEAD_INIT, |
| "perf", /* m_name */ |
| "", /* m_doc */ |
| -1, /* m_size */ |
| perf__methods, /* m_methods */ |
| NULL, /* m_reload */ |
| NULL, /* m_traverse */ |
| NULL, /* m_clear */ |
| NULL, /* m_free */ |
| }; |
| PyObject *module = PyModule_Create(&moduledef); |
| #endif |
| |
| if (module == NULL || |
| pyrf_event__setup_types() < 0 || |
| pyrf_evlist__setup_types() < 0 || |
| pyrf_evsel__setup_types() < 0 || |
| pyrf_thread_map__setup_types() < 0 || |
| pyrf_cpu_map__setup_types() < 0) |
| #if PY_MAJOR_VERSION < 3 |
| return; |
| #else |
| return module; |
| #endif |
| |
| /* The page_size is placed in util object. */ |
| page_size = sysconf(_SC_PAGE_SIZE); |
| |
| Py_INCREF(&pyrf_evlist__type); |
| PyModule_AddObject(module, "evlist", (PyObject*)&pyrf_evlist__type); |
| |
| Py_INCREF(&pyrf_evsel__type); |
| PyModule_AddObject(module, "evsel", (PyObject*)&pyrf_evsel__type); |
| |
| Py_INCREF(&pyrf_mmap_event__type); |
| PyModule_AddObject(module, "mmap_event", (PyObject *)&pyrf_mmap_event__type); |
| |
| Py_INCREF(&pyrf_lost_event__type); |
| PyModule_AddObject(module, "lost_event", (PyObject *)&pyrf_lost_event__type); |
| |
| Py_INCREF(&pyrf_comm_event__type); |
| PyModule_AddObject(module, "comm_event", (PyObject *)&pyrf_comm_event__type); |
| |
| Py_INCREF(&pyrf_task_event__type); |
| PyModule_AddObject(module, "task_event", (PyObject *)&pyrf_task_event__type); |
| |
| Py_INCREF(&pyrf_throttle_event__type); |
| PyModule_AddObject(module, "throttle_event", (PyObject *)&pyrf_throttle_event__type); |
| |
| Py_INCREF(&pyrf_task_event__type); |
| PyModule_AddObject(module, "task_event", (PyObject *)&pyrf_task_event__type); |
| |
| Py_INCREF(&pyrf_read_event__type); |
| PyModule_AddObject(module, "read_event", (PyObject *)&pyrf_read_event__type); |
| |
| Py_INCREF(&pyrf_sample_event__type); |
| PyModule_AddObject(module, "sample_event", (PyObject *)&pyrf_sample_event__type); |
| |
| Py_INCREF(&pyrf_context_switch_event__type); |
| PyModule_AddObject(module, "switch_event", (PyObject *)&pyrf_context_switch_event__type); |
| |
| Py_INCREF(&pyrf_thread_map__type); |
| PyModule_AddObject(module, "thread_map", (PyObject*)&pyrf_thread_map__type); |
| |
| Py_INCREF(&pyrf_cpu_map__type); |
| PyModule_AddObject(module, "cpu_map", (PyObject*)&pyrf_cpu_map__type); |
| |
| dict = PyModule_GetDict(module); |
| if (dict == NULL) |
| goto error; |
| |
| for (i = 0; perf__constants[i].name != NULL; i++) { |
| obj = _PyLong_FromLong(perf__constants[i].value); |
| if (obj == NULL) |
| goto error; |
| PyDict_SetItemString(dict, perf__constants[i].name, obj); |
| Py_DECREF(obj); |
| } |
| |
| error: |
| if (PyErr_Occurred()) |
| PyErr_SetString(PyExc_ImportError, "perf: Init failed!"); |
| #if PY_MAJOR_VERSION >= 3 |
| return module; |
| #endif |
| } |
| |
| /* |
| * Dummy, to avoid dragging all the test_attr infrastructure in the python |
| * binding. |
| */ |
| void test_attr__open(struct perf_event_attr *attr, pid_t pid, int cpu, |
| int fd, int group_fd, unsigned long flags) |
| { |
| } |