Check if channel has closed stream in channel poll for CPU hotplug
[lttng-modules.git] / ltt-events.h
... / ...
CommitLineData
1#ifndef _LTT_EVENTS_H
2#define _LTT_EVENTS_H
3
4/*
5 * ltt-events.h
6 *
7 * Copyright 2010 (c) - Mathieu Desnoyers <mathieu.desnoyers@efficios.com>
8 *
9 * Holds LTTng per-session event registry.
10 *
11 * Dual LGPL v2.1/GPL v2 license.
12 */
13
14#include <linux/list.h>
15#include <linux/kprobes.h>
16#include "wrapper/uuid.h"
17#include "ltt-debugfs-abi.h"
18
19#undef is_signed_type
20#define is_signed_type(type) (((type)(-1)) < 0)
21
22struct ltt_channel;
23struct ltt_session;
24struct lib_ring_buffer_ctx;
25struct perf_event;
26struct perf_event_attr;
27
28/* Type description */
29
30/* Update the astract_types name table in lttng-types.c along with this enum */
31enum abstract_types {
32 atype_integer,
33 atype_enum,
34 atype_array,
35 atype_sequence,
36 atype_string,
37 NR_ABSTRACT_TYPES,
38};
39
40/* Update the string_encodings name table in lttng-types.c along with this enum */
41enum lttng_string_encodings {
42 lttng_encode_none = 0,
43 lttng_encode_UTF8 = 1,
44 lttng_encode_ASCII = 2,
45 NR_STRING_ENCODINGS,
46};
47
48struct lttng_enum_entry {
49 unsigned long long start, end; /* start and end are inclusive */
50 const char *string;
51};
52
53#define __type_integer(_type, _byte_order, _base, _encoding) \
54 { \
55 .atype = atype_integer, \
56 .u.basic.integer = \
57 { \
58 .size = sizeof(_type) * CHAR_BIT, \
59 .alignment = ltt_alignof(_type) * CHAR_BIT, \
60 .signedness = is_signed_type(_type), \
61 .reverse_byte_order = _byte_order != __BYTE_ORDER, \
62 .base = _base, \
63 .encoding = lttng_encode_##_encoding, \
64 }, \
65 } \
66
67struct lttng_integer_type {
68 unsigned int size; /* in bits */
69 unsigned short alignment; /* in bits */
70 unsigned int signedness:1;
71 unsigned int reverse_byte_order:1;
72 unsigned int base; /* 2, 8, 10, 16, for pretty print */
73 enum lttng_string_encodings encoding;
74};
75
76union _lttng_basic_type {
77 struct lttng_integer_type integer;
78 struct {
79 const char *name;
80 } enumeration;
81 struct {
82 enum lttng_string_encodings encoding;
83 } string;
84};
85
86struct lttng_basic_type {
87 enum abstract_types atype;
88 union {
89 union _lttng_basic_type basic;
90 } u;
91};
92
93struct lttng_type {
94 enum abstract_types atype;
95 union {
96 union _lttng_basic_type basic;
97 struct {
98 struct lttng_basic_type elem_type;
99 unsigned int length; /* num. elems. */
100 } array;
101 struct {
102 struct lttng_basic_type length_type;
103 struct lttng_basic_type elem_type;
104 } sequence;
105 } u;
106};
107
108struct lttng_enum {
109 const char *name;
110 struct lttng_type container_type;
111 const struct lttng_enum_entry *entries;
112 unsigned int len;
113};
114
115/* Event field description */
116
117struct lttng_event_field {
118 const char *name;
119 struct lttng_type type;
120};
121
122struct lttng_ctx_field {
123 struct lttng_event_field event_field;
124 size_t (*get_size)(size_t offset);
125 void (*record)(struct lttng_ctx_field *field,
126 struct lib_ring_buffer_ctx *ctx,
127 struct ltt_channel *chan);
128 union {
129 struct {
130 struct perf_event **e; /* per-cpu array */
131 struct notifier_block nb;
132 int hp_enable;
133 struct perf_event_attr *attr;
134 } perf_counter;
135 } u;
136 void (*destroy)(struct lttng_ctx_field *field);
137};
138
139struct lttng_ctx {
140 struct lttng_ctx_field *fields;
141 unsigned int nr_fields;
142 unsigned int allocated_fields;
143};
144
145struct lttng_event_desc {
146 const char *name;
147 void *probe_callback;
148 const struct lttng_event_ctx *ctx; /* context */
149 const struct lttng_event_field *fields; /* event payload */
150 unsigned int nr_fields;
151 struct module *owner;
152};
153
154struct lttng_probe_desc {
155 const struct lttng_event_desc *event_desc;
156 unsigned int nr_events;
157 struct list_head head; /* chain registered probes */
158};
159
160/*
161 * ltt_event structure is referred to by the tracing fast path. It must be
162 * kept small.
163 */
164struct ltt_event {
165 unsigned int id;
166 struct ltt_channel *chan;
167 int enabled;
168 const struct lttng_event_desc *desc;
169 void *filter;
170 struct lttng_ctx *ctx;
171 enum lttng_kernel_instrumentation instrumentation;
172 union {
173 struct {
174 struct kprobe kp;
175 char *symbol_name;
176 } kprobe;
177 struct {
178 char *symbol_name;
179 } ftrace;
180 } u;
181 struct list_head list; /* Event list */
182 int metadata_dumped:1;
183};
184
185struct ltt_channel_ops {
186 struct channel *(*channel_create)(const char *name,
187 struct ltt_channel *ltt_chan,
188 void *buf_addr,
189 size_t subbuf_size, size_t num_subbuf,
190 unsigned int switch_timer_interval,
191 unsigned int read_timer_interval);
192 void (*channel_destroy)(struct channel *chan);
193 struct lib_ring_buffer *(*buffer_read_open)(struct channel *chan);
194 int (*buffer_has_read_closed_stream)(struct channel *chan);
195 void (*buffer_read_close)(struct lib_ring_buffer *buf);
196 int (*event_reserve)(struct lib_ring_buffer_ctx *ctx,
197 uint32_t event_id);
198 void (*event_commit)(struct lib_ring_buffer_ctx *ctx);
199 void (*event_write)(struct lib_ring_buffer_ctx *ctx, const void *src,
200 size_t len);
201 /*
202 * packet_avail_size returns the available size in the current
203 * packet. Note that the size returned is only a hint, since it
204 * may change due to concurrent writes.
205 */
206 size_t (*packet_avail_size)(struct channel *chan);
207 wait_queue_head_t *(*get_reader_wait_queue)(struct channel *chan);
208 wait_queue_head_t *(*get_hp_wait_queue)(struct channel *chan);
209 int (*is_finalized)(struct channel *chan);
210 int (*is_disabled)(struct channel *chan);
211};
212
213struct ltt_channel {
214 unsigned int id;
215 struct channel *chan; /* Channel buffers */
216 int enabled;
217 struct lttng_ctx *ctx;
218 /* Event ID management */
219 struct ltt_session *session;
220 struct file *file; /* File associated to channel */
221 unsigned int free_event_id; /* Next event ID to allocate */
222 struct list_head list; /* Channel list */
223 struct ltt_channel_ops *ops;
224 int header_type; /* 0: unset, 1: compact, 2: large */
225 int metadata_dumped:1;
226};
227
228struct ltt_session {
229 int active; /* Is trace session active ? */
230 int been_active; /* Has trace session been active ? */
231 struct file *file; /* File associated to session */
232 struct ltt_channel *metadata; /* Metadata channel */
233 struct list_head chan; /* Channel list head */
234 struct list_head events; /* Event list head */
235 struct list_head list; /* Session list */
236 unsigned int free_chan_id; /* Next chan ID to allocate */
237 uuid_le uuid; /* Trace session unique ID */
238 int metadata_dumped:1;
239};
240
241struct ltt_transport {
242 char *name;
243 struct module *owner;
244 struct list_head node;
245 struct ltt_channel_ops ops;
246};
247
248struct ltt_session *ltt_session_create(void);
249int ltt_session_enable(struct ltt_session *session);
250int ltt_session_disable(struct ltt_session *session);
251void ltt_session_destroy(struct ltt_session *session);
252
253struct ltt_channel *ltt_channel_create(struct ltt_session *session,
254 const char *transport_name,
255 void *buf_addr,
256 size_t subbuf_size, size_t num_subbuf,
257 unsigned int switch_timer_interval,
258 unsigned int read_timer_interval);
259struct ltt_channel *ltt_global_channel_create(struct ltt_session *session,
260 int overwrite, void *buf_addr,
261 size_t subbuf_size, size_t num_subbuf,
262 unsigned int switch_timer_interval,
263 unsigned int read_timer_interval);
264
265struct ltt_event *ltt_event_create(struct ltt_channel *chan,
266 struct lttng_kernel_event *event_param,
267 void *filter);
268
269int ltt_channel_enable(struct ltt_channel *channel);
270int ltt_channel_disable(struct ltt_channel *channel);
271int ltt_event_enable(struct ltt_event *event);
272int ltt_event_disable(struct ltt_event *event);
273
274void ltt_transport_register(struct ltt_transport *transport);
275void ltt_transport_unregister(struct ltt_transport *transport);
276
277void synchronize_trace(void);
278int ltt_debugfs_abi_init(void);
279void ltt_debugfs_abi_exit(void);
280
281int ltt_probe_register(struct lttng_probe_desc *desc);
282void ltt_probe_unregister(struct lttng_probe_desc *desc);
283const struct lttng_event_desc *ltt_event_get(const char *name);
284void ltt_event_put(const struct lttng_event_desc *desc);
285int ltt_probes_init(void);
286void ltt_probes_exit(void);
287struct lttng_ctx_field *lttng_append_context(struct lttng_ctx **ctx);
288int lttng_find_context(struct lttng_ctx *ctx, const char *name);
289void lttng_remove_context_field(struct lttng_ctx **ctx,
290 struct lttng_ctx_field *field);
291void lttng_destroy_context(struct lttng_ctx *ctx);
292int lttng_add_pid_to_ctx(struct lttng_ctx **ctx);
293int lttng_add_comm_to_ctx(struct lttng_ctx **ctx);
294int lttng_add_prio_to_ctx(struct lttng_ctx **ctx);
295int lttng_add_nice_to_ctx(struct lttng_ctx **ctx);
296int lttng_add_vpid_to_ctx(struct lttng_ctx **ctx);
297int lttng_add_tid_to_ctx(struct lttng_ctx **ctx);
298int lttng_add_vtid_to_ctx(struct lttng_ctx **ctx);
299int lttng_add_ppid_to_ctx(struct lttng_ctx **ctx);
300int lttng_add_vppid_to_ctx(struct lttng_ctx **ctx);
301#ifdef CONFIG_PERF_EVENTS
302int lttng_add_perf_counter_to_ctx(uint32_t type,
303 uint64_t config,
304 const char *name,
305 struct lttng_ctx **ctx);
306#else
307static inline
308int lttng_add_perf_counter_to_ctx(uint32_t type,
309 uint64_t config,
310 const char *name,
311 struct lttng_ctx **ctx)
312{
313 return -ENOSYS;
314}
315#endif
316
317#ifdef CONFIG_KPROBES
318int lttng_kprobes_register(const char *name,
319 const char *symbol_name,
320 uint64_t offset,
321 uint64_t addr,
322 struct ltt_event *event);
323void lttng_kprobes_unregister(struct ltt_event *event);
324void lttng_kprobes_destroy_private(struct ltt_event *event);
325#else
326static inline
327int lttng_kprobes_register(const char *name,
328 const char *symbol_name,
329 uint64_t offset,
330 uint64_t addr,
331 struct ltt_event *event)
332{
333 return -ENOSYS;
334}
335
336static inline
337void lttng_kprobes_unregister(struct ltt_event *event)
338{
339}
340
341static inline
342void lttng_kprobes_destroy_private(struct ltt_event *event)
343{
344}
345#endif
346
347#ifdef CONFIG_DYNAMIC_FTRACE
348int lttng_ftrace_register(const char *name,
349 const char *symbol_name,
350 struct ltt_event *event);
351void lttng_ftrace_unregister(struct ltt_event *event);
352void lttng_ftrace_destroy_private(struct ltt_event *event);
353#else
354static inline
355int lttng_ftrace_register(const char *name,
356 const char *symbol_name,
357 struct ltt_event *event)
358{
359 return -ENOSYS;
360}
361
362static inline
363void lttng_ftrace_unregister(struct ltt_event *event)
364{
365}
366
367static inline
368void lttng_ftrace_destroy_private(struct ltt_event *event)
369{
370}
371#endif
372
373extern const struct file_operations lttng_tracepoint_list_fops;
374
375#if (LINUX_VERSION_CODE >= KERNEL_VERSION(2,6,35))
376#define TRACEPOINT_HAS_DATA_ARG
377#endif
378
379#endif /* _LTT_EVENTS_H */
This page took 0.02348 seconds and 4 git commands to generate.