2 * Copyright (C) 2013 Stefan Sauer <ensonic@users.sf.net>
4 * gststats.c: tracing module that logs events
6 * This library is free software; you can redistribute it and/or
7 * modify it under the terms of the GNU Library General Public
8 * License as published by the Free Software Foundation; either
9 * version 2 of the License, or (at your option) any later version.
11 * This library 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 GNU
14 * Library General Public License for more details.
16 * You should have received a copy of the GNU Library General Public
17 * License along with this library; if not, write to the
18 * Free Software Foundation, Inc., 51 Franklin St, Fifth Floor,
19 * Boston, MA 02110-1301, USA.
23 * @short_description: log event stats
25 * A tracing module that builds usage statistic for elements and pads.
33 #include <gst/gsttracerrecord.h>
37 GST_DEBUG_CATEGORY_STATIC (gst_stats_debug);
38 #define GST_CAT_DEFAULT gst_stats_debug
40 static GQuark data_quark;
41 G_LOCK_DEFINE (_elem_stats);
42 G_LOCK_DEFINE (_pad_stats);
45 GST_DEBUG_CATEGORY_INIT (gst_stats_debug, "stats", 0, "stats tracer"); \
46 data_quark = g_quark_from_static_string ("gststats:data");
47 #define gst_stats_tracer_parent_class parent_class
48 G_DEFINE_TYPE_WITH_CODE (GstStatsTracer, gst_stats_tracer, GST_TYPE_TRACER,
51 static GstTracerRecord *tr_new_element;
52 static GstTracerRecord *tr_new_pad;
53 static GstTracerRecord *tr_buffer;
54 static GstTracerRecord *tr_element_query;
55 static GstTracerRecord *tr_event;
56 static GstTracerRecord *tr_message;
57 static GstTracerRecord *tr_query;
61 /* we can't rely on the address to be unique over time */
71 /* we can't rely on the address to be unique over time */
75 /* time spend in this element */
83 static GstElementStats no_elem_stats = { 0, };
85 static GstElementStats *
86 fill_element_stats (GstStatsTracer * self, GstElement * element)
88 GstElementStats *stats = g_slice_new0 (GstElementStats);
90 stats->index = self->num_elements++;
91 stats->parent_ix = G_MAXUINT;
96 log_new_element_stats (GstElementStats * stats, GstElement * element,
99 gst_tracer_record_log (tr_new_element, (guint64) g_thread_self (),
100 elapsed, stats->index, stats->parent_ix, GST_OBJECT_NAME (element),
101 G_OBJECT_TYPE_NAME (element), GST_IS_BIN (element));
105 free_element_stats (gpointer data)
107 g_slice_free (GstElementStats, data);
110 static GstElementStats *
111 create_element_stats (GstStatsTracer * self, GstElement * element)
113 GstElementStats *stats;
115 stats = fill_element_stats (self, element);
116 g_object_set_qdata_full ((GObject *) element, data_quark, stats,
122 static inline GstElementStats *
123 get_element_stats (GstStatsTracer * self, GstElement * element)
125 GstElementStats *stats;
126 gboolean is_new = FALSE;
129 no_elem_stats.index = G_MAXUINT;
130 return &no_elem_stats;
133 G_LOCK (_elem_stats);
134 if (!(stats = g_object_get_qdata ((GObject *) element, data_quark))) {
135 stats = create_element_stats (self, element);
138 G_UNLOCK (_elem_stats);
139 if (G_UNLIKELY (stats->parent_ix == G_MAXUINT)) {
140 GstElement *parent = GST_ELEMENT_PARENT (element);
142 GstElementStats *parent_stats = get_element_stats (self, parent);
143 stats->parent_ix = parent_stats->index;
146 if (G_UNLIKELY (is_new)) {
147 log_new_element_stats (stats, element, GST_CLOCK_TIME_NONE);
153 * Get the element/bin owning the pad.
159 * out: the element that contains the peer of the proxy
162 * out: the bin owning the ghostpad
164 /* TODO(ensonic): gst_pad_get_parent_element() would not work here, should we
165 * add this as new api, e.g. gst_pad_find_parent_element();
168 get_real_pad_parent (GstPad * pad)
175 parent = GST_OBJECT_PARENT (pad);
177 /* if parent of pad is a ghost-pad, then pad is a proxy_pad */
178 if (parent && GST_IS_GHOST_PAD (parent)) {
179 pad = GST_PAD_CAST (parent);
180 parent = GST_OBJECT_PARENT (pad);
182 return GST_ELEMENT_CAST (parent);
185 static GstPadStats no_pad_stats = { 0, };
188 fill_pad_stats (GstStatsTracer * self, GstPad * pad)
190 GstPadStats *stats = g_slice_new0 (GstPadStats);
192 stats->index = self->num_pads++;
193 stats->parent_ix = G_MAXUINT;
199 log_new_pad_stats (GstPadStats * stats, GstPad * pad)
201 gst_tracer_record_log (tr_new_element, (guint64) g_thread_self (),
202 stats->index, stats->parent_ix, GST_OBJECT_NAME (pad),
203 G_OBJECT_TYPE_NAME (pad), GST_IS_GHOST_PAD (pad),
204 GST_PAD_DIRECTION (pad));
208 free_pad_stats (gpointer data)
210 g_slice_free (GstPadStats, data);
214 get_pad_stats (GstStatsTracer * self, GstPad * pad)
217 gboolean is_new = FALSE;
220 no_pad_stats.index = G_MAXUINT;
221 return &no_pad_stats;
225 if (!(stats = g_object_get_qdata ((GObject *) pad, data_quark))) {
226 stats = fill_pad_stats (self, pad);
227 g_object_set_qdata_full ((GObject *) pad, data_quark, stats,
231 G_UNLOCK (_pad_stats);
232 if (G_UNLIKELY (stats->parent_ix == G_MAXUINT)) {
233 GstElement *elem = get_real_pad_parent (pad);
235 GstElementStats *elem_stats = get_element_stats (self, elem);
237 stats->parent_ix = elem_stats->index;
240 if (G_UNLIKELY (is_new)) {
241 log_new_pad_stats (stats, pad);
247 do_buffer_stats (GstStatsTracer * self, GstPad * this_pad,
248 GstPadStats * this_pad_stats, GstPad * that_pad,
249 GstPadStats * that_pad_stats, GstBuffer * buf, GstClockTime elapsed)
251 GstElement *this_elem = get_real_pad_parent (this_pad);
252 GstElementStats *this_elem_stats = get_element_stats (self, this_elem);
253 GstElement *that_elem = get_real_pad_parent (that_pad);
254 GstElementStats *that_elem_stats = get_element_stats (self, that_elem);
256 gst_tracer_record_log (tr_buffer, (guint64) g_thread_self (), elapsed,
257 this_pad_stats->index, this_elem_stats->index, that_pad_stats->index,
258 that_elem_stats->index, gst_buffer_get_size (buf), GST_BUFFER_PTS (buf),
259 GST_BUFFER_DTS (buf), GST_BUFFER_DURATION (buf), GST_BUFFER_FLAGS (buf));
263 do_query_stats (GstStatsTracer * self, GstPad * this_pad,
264 GstPadStats * this_pad_stats, GstPad * that_pad,
265 GstPadStats * that_pad_stats, GstQuery * qry, GstClockTime elapsed,
266 gboolean have_res, gboolean res)
268 GstElement *this_elem = get_real_pad_parent (this_pad);
269 GstElementStats *this_elem_stats = get_element_stats (self, this_elem);
270 GstElement *that_elem = get_real_pad_parent (that_pad);
271 GstElementStats *that_elem_stats = get_element_stats (self, that_elem);
273 gst_tracer_record_log (tr_query, (guint64) g_thread_self (), elapsed,
274 this_pad_stats->index, this_elem_stats->index, that_pad_stats->index,
275 that_elem_stats->index, GST_QUERY_TYPE_NAME (qry),
276 gst_query_get_structure (qry), have_res, res);
280 do_element_stats (GstStatsTracer * self, GstPad * pad, GstClockTime elapsed1,
281 GstClockTime elapsed2)
283 GstClockTimeDiff elapsed = GST_CLOCK_DIFF (elapsed1, elapsed2);
284 GstObject *parent = GST_OBJECT_PARENT (pad);
286 GST_ELEMENT_CAST (GST_IS_PAD (parent) ? GST_OBJECT_PARENT (parent) :
288 GstElementStats *this_stats = get_element_stats (self, this);
289 GstPad *peer_pad = GST_PAD_PEER (pad);
290 GstElementStats *peer_stats;
295 /* walk the ghost pad chain downstream to get the real pad */
296 /* if parent of peer_pad is a ghost-pad, then peer_pad is a proxy_pad */
297 parent = GST_OBJECT_PARENT (peer_pad);
298 if (parent && GST_IS_GHOST_PAD (parent)) {
299 peer_pad = GST_PAD_CAST (parent);
300 /* if this is now the ghost pad, get the peer of this */
301 get_pad_stats (self, peer_pad);
302 if ((parent = GST_OBJECT_PARENT (peer_pad))) {
303 get_element_stats (self, GST_ELEMENT_CAST (parent));
305 peer_pad = GST_PAD_PEER (GST_GHOST_PAD_CAST (peer_pad));
306 parent = peer_pad ? GST_OBJECT_PARENT (peer_pad) : NULL;
308 /* walk the ghost pad chain upstream to get the real pad */
309 /* if peer_pad is a ghost-pad, then parent is a bin and it is the parent of
311 while (peer_pad && GST_IS_GHOST_PAD (peer_pad)) {
312 get_pad_stats (self, peer_pad);
313 get_element_stats (self, GST_ELEMENT_CAST (parent));
314 peer_pad = gst_ghost_pad_get_target (GST_GHOST_PAD_CAST (peer_pad));
315 parent = peer_pad ? GST_OBJECT_PARENT (peer_pad) : NULL;
319 printf ("%" GST_TIME_FORMAT
320 " transmission on unparented target pad %s_%s -> %s_%s\n",
321 GST_TIME_ARGS (elapsed), GST_DEBUG_PAD_NAME (pad),
322 GST_DEBUG_PAD_NAME (peer_pad));
325 peer_stats = get_element_stats (self, GST_ELEMENT_CAST (parent));
327 /* we'd like to gather time spend in each element, but this does not make too
329 * pure push/pull-based:
330 * - the time spend in the push/pull_range is accounted for the peer and
331 * removed from the current element
332 * - this works for chains
333 * - drawback is sink elements that block to sync have a high time usage
334 * - we could rerun the ests with sync=false
336 * - a.g. demuxers both push and pull. thus we subtract time for the pull
337 * and the push operations, but never add anything.
338 * - can we start a counter after push/pull in such elements and add then
339 * time to the element upon next pad activity?
342 /* this does not make sense for demuxers */
343 this_stats->treal -= elapsed;
344 peer_stats->treal += elapsed;
346 /* this creates several >100% figures */
347 this_stats->treal += GST_CLOCK_DIFF (this_stats->last_ts, elapsed2) - elapsed;
348 peer_stats->treal += elapsed;
349 this_stats->last_ts = elapsed2;
350 peer_stats->last_ts = elapsed2;
357 do_push_buffer_pre (GstStatsTracer * self, guint64 ts, GstPad * this_pad,
360 GstPadStats *this_pad_stats = get_pad_stats (self, this_pad);
361 GstPad *that_pad = GST_PAD_PEER (this_pad);
362 GstPadStats *that_pad_stats = get_pad_stats (self, that_pad);
364 do_buffer_stats (self, this_pad, this_pad_stats, that_pad, that_pad_stats,
369 do_push_buffer_post (GstStatsTracer * self, guint64 ts, GstPad * pad,
372 GstPadStats *stats = get_pad_stats (self, pad);
374 do_element_stats (self, pad, stats->last_ts, ts);
379 GstStatsTracer *self;
381 GstPadStats *this_pad_stats;
383 GstPadStats *that_pad_stats;
385 } DoPushBufferListArgs;
388 do_push_buffer_list_item (GstBuffer ** buffer, guint idx, gpointer user_data)
390 DoPushBufferListArgs *args = (DoPushBufferListArgs *) user_data;
392 do_buffer_stats (args->self, args->this_pad, args->this_pad_stats,
393 args->that_pad, args->that_pad_stats, *buffer, args->ts);
398 do_push_buffer_list_pre (GstStatsTracer * self, guint64 ts, GstPad * this_pad,
399 GstBufferList * list)
401 GstPadStats *this_pad_stats = get_pad_stats (self, this_pad);
402 GstPad *that_pad = GST_PAD_PEER (this_pad);
403 GstPadStats *that_pad_stats = get_pad_stats (self, that_pad);
404 DoPushBufferListArgs args = { self, this_pad, this_pad_stats, that_pad,
408 gst_buffer_list_foreach (list, do_push_buffer_list_item, &args);
412 do_push_buffer_list_post (GstStatsTracer * self, guint64 ts, GstPad * pad,
415 GstPadStats *stats = get_pad_stats (self, pad);
417 do_element_stats (self, pad, stats->last_ts, ts);
421 do_pull_range_pre (GstStatsTracer * self, guint64 ts, GstPad * pad)
423 GstPadStats *stats = get_pad_stats (self, pad);
428 do_pull_range_post (GstStatsTracer * self, guint64 ts, GstPad * this_pad,
431 GstPadStats *this_pad_stats = get_pad_stats (self, this_pad);
432 guint64 last_ts = this_pad_stats->last_ts;
433 GstPad *that_pad = GST_PAD_PEER (this_pad);
434 GstPadStats *that_pad_stats = get_pad_stats (self, that_pad);
436 if (buffer != NULL) {
437 do_buffer_stats (self, this_pad, this_pad_stats, that_pad, that_pad_stats,
440 do_element_stats (self, this_pad, last_ts, ts);
444 do_push_event_pre (GstStatsTracer * self, guint64 ts, GstPad * pad,
447 GstElement *elem = get_real_pad_parent (pad);
448 GstElementStats *elem_stats = get_element_stats (self, elem);
449 GstPadStats *pad_stats = get_pad_stats (self, pad);
451 elem_stats->last_ts = ts;
452 gst_tracer_record_log (tr_event, (guint64) g_thread_self (), ts,
453 pad_stats->index, elem_stats->index, GST_EVENT_TYPE_NAME (ev));
457 do_post_message_pre (GstStatsTracer * self, guint64 ts, GstElement * elem,
460 GstElementStats *stats = get_element_stats (self, elem);
461 const GstStructure *msg_s = gst_message_get_structure (msg);
464 gst_tracer_record_log (tr_message, (guint64) g_thread_self (), ts,
465 stats->index, GST_MESSAGE_TYPE_NAME (msg),
466 (msg_s ? msg_s : gst_structure_new_empty ("dummy")));
470 do_element_new (GstStatsTracer * self, guint64 ts, GstElement * elem)
472 GstElementStats *stats;
474 stats = create_element_stats (self, elem);
475 log_new_element_stats (stats, elem, ts);
479 do_element_query_pre (GstStatsTracer * self, guint64 ts, GstElement * elem,
482 GstElementStats *stats = get_element_stats (self, elem);
485 gst_tracer_record_log (tr_element_query, (guint64) g_thread_self (), ts,
486 stats->index, GST_QUERY_TYPE_NAME (qry));
490 do_query_pre (GstStatsTracer * self, guint64 ts, GstPad * this_pad,
493 GstPadStats *this_pad_stats = get_pad_stats (self, this_pad);
494 GstPad *that_pad = GST_PAD_PEER (this_pad);
495 GstPadStats *that_pad_stats = get_pad_stats (self, that_pad);
497 do_query_stats (self, this_pad, this_pad_stats, that_pad, that_pad_stats,
498 qry, ts, FALSE, FALSE);
502 do_query_post (GstStatsTracer * self, guint64 ts, GstPad * this_pad,
503 GstQuery * qry, gboolean res)
505 GstPadStats *this_pad_stats = get_pad_stats (self, this_pad);
506 GstPad *that_pad = GST_PAD_PEER (this_pad);
507 GstPadStats *that_pad_stats = get_pad_stats (self, that_pad);
509 do_query_stats (self, this_pad, this_pad_stats, that_pad, that_pad_stats,
516 gst_stats_tracer_class_init (GstStatsTracerClass * klass)
518 /* announce trace formats */
520 tr_buffer = gst_tracer_record_new (gst_structure_new ("buffer.class",
521 "thread-id", GST_TYPE_STRUCTURE, gst_structure_new ("scope",
522 "type", G_TYPE_GTYPE, G_TYPE_UINT64,
523 "related-to", G_TYPE_STRING, "thread", /* TODO use genum */
525 "ts", GST_TYPE_STRUCTURE, gst_structure_new ("value",
526 "type", G_TYPE_GTYPE, G_TYPE_UINT64,
527 "description", G_TYPE_STRING, "event ts",
529 "pad-ix", GST_TYPE_STRUCTURE, gst_structure_new ("scope",
530 "type", G_TYPE_GTYPE, G_TYPE_UINT,
531 "related-to", G_TYPE_STRING, "pad", /* TODO: use genum */
533 "element-ix", GST_TYPE_STRUCTURE, gst_structure_new ("scope",
534 "type", G_TYPE_GTYPE, G_TYPE_UINT,
535 "related-to", G_TYPE_STRING, "element", /* TODO: use genum */
537 "peer-pad-ix", GST_TYPE_STRUCTURE, gst_structure_new ("scope",
538 "type", G_TYPE_GTYPE, G_TYPE_UINT,
539 "related-to", G_TYPE_STRING, "pad", /* TODO: use genum */
541 "peer-element-ix", GST_TYPE_STRUCTURE, gst_structure_new ("scope",
542 "type", G_TYPE_GTYPE, G_TYPE_UINT,
543 "related-to", G_TYPE_STRING, "element", /* TODO: use genum */
545 "buffer-size", GST_TYPE_STRUCTURE, gst_structure_new ("value",
546 "type", G_TYPE_GTYPE, G_TYPE_UINT,
547 "description", G_TYPE_STRING, "size of buffer in bytes",
548 "flags", G_TYPE_STRING, "", /* TODO: use gflags */
549 "min", G_TYPE_UINT, 0,
550 "max", G_TYPE_UINT, G_MAXUINT,
552 "buffer-ts", GST_TYPE_STRUCTURE, gst_structure_new ("value",
553 "type", G_TYPE_GTYPE, G_TYPE_UINT64,
554 "description", G_TYPE_STRING, "timestamp of the buffer in ns",
555 "flags", G_TYPE_STRING, "", /* TODO: use gflags */
556 "min", G_TYPE_UINT64, G_GUINT64_CONSTANT (0),
557 "max", G_TYPE_UINT64, G_MAXUINT64,
559 "buffer-duration", GST_TYPE_STRUCTURE, gst_structure_new ("value",
560 "type", G_TYPE_GTYPE, G_TYPE_UINT64,
561 "description", G_TYPE_STRING, "duration of the buffer in ns",
562 "flags", G_TYPE_STRING, "", /* TODO: use gflags */
563 "min", G_TYPE_UINT64, G_GUINT64_CONSTANT (0),
564 "max", G_TYPE_UINT64, G_MAXUINT64,
566 /* TODO(ensonic): "buffer-flags" */
568 tr_event = gst_tracer_record_new (gst_structure_new ("event.class",
569 "thread-id", GST_TYPE_STRUCTURE, gst_structure_new ("scope",
570 "type", G_TYPE_GTYPE, G_TYPE_UINT64,
571 "related-to", G_TYPE_STRING, "thread", /* TODO use genum */
573 "ts", GST_TYPE_STRUCTURE, gst_structure_new ("value",
574 "type", G_TYPE_GTYPE, G_TYPE_UINT64,
575 "description", G_TYPE_STRING, "event ts",
577 "pad-ix", GST_TYPE_STRUCTURE, gst_structure_new ("scope",
578 "type", G_TYPE_GTYPE, G_TYPE_UINT,
579 "related-to", G_TYPE_STRING, "pad", /* TODO: use genum */
581 "element-ix", GST_TYPE_STRUCTURE, gst_structure_new ("scope",
582 "type", G_TYPE_GTYPE, G_TYPE_UINT,
583 "related-to", G_TYPE_STRING, "element", /* TODO: use genum */
585 "name", GST_TYPE_STRUCTURE, gst_structure_new ("value",
586 "type", G_TYPE_GTYPE, G_TYPE_STRING,
587 "description", G_TYPE_STRING, "name of the event",
588 "flags", G_TYPE_STRING, "", /* TODO: use gflags */
591 tr_message = gst_tracer_record_new (gst_structure_new ("message.class",
592 "thread-id", GST_TYPE_STRUCTURE, gst_structure_new ("scope",
593 "type", G_TYPE_GTYPE, G_TYPE_UINT64,
594 "related-to", G_TYPE_STRING, "thread", /* TODO use genum */
596 "ts", GST_TYPE_STRUCTURE, gst_structure_new ("value",
597 "type", G_TYPE_GTYPE, G_TYPE_UINT64,
598 "description", G_TYPE_STRING, "event ts",
600 "element-ix", GST_TYPE_STRUCTURE, gst_structure_new ("scope",
601 "type", G_TYPE_GTYPE, G_TYPE_UINT,
602 "related-to", G_TYPE_STRING, "element", /* TODO: use genum */
604 "name", GST_TYPE_STRUCTURE, gst_structure_new ("value",
605 "type", G_TYPE_GTYPE, G_TYPE_STRING,
606 "description", G_TYPE_STRING, "name of the message",
607 "flags", G_TYPE_STRING, "", /* TODO: use gflags */
609 "structure", GST_TYPE_STRUCTURE, gst_structure_new ("structure",
610 "type", G_TYPE_GTYPE, GST_TYPE_STRUCTURE,
611 "description", G_TYPE_STRING, "message structure",
614 tr_element_query = gst_tracer_record_new (gst_structure_new (
615 "element-query.class",
616 "thread-id", GST_TYPE_STRUCTURE, gst_structure_new ("scope",
617 "type", G_TYPE_GTYPE, G_TYPE_UINT64,
618 "related-to", G_TYPE_STRING, "thread", /* TODO use genum */
620 "ts", GST_TYPE_STRUCTURE, gst_structure_new ("value",
621 "type", G_TYPE_GTYPE, G_TYPE_UINT64,
622 "description", G_TYPE_STRING, "event ts",
624 "element-ix", GST_TYPE_STRUCTURE, gst_structure_new ("scope",
625 "type", G_TYPE_GTYPE, G_TYPE_UINT,
626 "related-to", G_TYPE_STRING, "element", /* TODO: use genum */
628 "name", GST_TYPE_STRUCTURE, gst_structure_new ("value",
629 "type", G_TYPE_GTYPE, G_TYPE_STRING,
630 "description", G_TYPE_STRING, "name of the query",
631 "flags", G_TYPE_STRING, "", /* TODO: use gflags */
634 tr_query = gst_tracer_record_new (gst_structure_new ("query.class",
635 "thread-id", GST_TYPE_STRUCTURE, gst_structure_new ("scope",
636 "type", G_TYPE_GTYPE, G_TYPE_UINT64,
637 "related-to", G_TYPE_STRING, "thread", /* TODO use genum */
639 "ts", GST_TYPE_STRUCTURE, gst_structure_new ("value",
640 "type", G_TYPE_GTYPE, G_TYPE_UINT64,
641 "description", G_TYPE_STRING, "event ts",
643 "pad-ix", GST_TYPE_STRUCTURE, gst_structure_new ("scope",
644 "type", G_TYPE_GTYPE, G_TYPE_UINT,
645 "related-to", G_TYPE_STRING, "pad", /* TODO: use genum */
647 "element-ix", GST_TYPE_STRUCTURE, gst_structure_new ("scope",
648 "type", G_TYPE_GTYPE, G_TYPE_UINT,
649 "related-to", G_TYPE_STRING, "element", /* TODO: use genum */
651 "peer-pad-ix", GST_TYPE_STRUCTURE, gst_structure_new ("scope",
652 "type", G_TYPE_GTYPE, G_TYPE_UINT,
653 "related-to", G_TYPE_STRING, "pad", /* TODO: use genum */
655 "peer-element-ix", GST_TYPE_STRUCTURE, gst_structure_new ("scope",
656 "type", G_TYPE_GTYPE, G_TYPE_UINT,
657 "related-to", G_TYPE_STRING, "element", /* TODO: use genum */
659 "name", GST_TYPE_STRUCTURE, gst_structure_new ("value",
660 "type", G_TYPE_GTYPE, G_TYPE_STRING,
661 "description", G_TYPE_STRING, "name of the query",
662 "flags", G_TYPE_STRING, "", /* TODO: use gflags */
664 "structure", GST_TYPE_STRUCTURE, gst_structure_new ("value",
665 "type", G_TYPE_GTYPE, GST_TYPE_STRUCTURE,
666 "description", G_TYPE_STRING, "query structure",
667 "flags", G_TYPE_STRING, "", /* TODO: use gflags */
669 "have-res", GST_TYPE_STRUCTURE, gst_structure_new ("value",
670 "type", G_TYPE_GTYPE, G_TYPE_BOOLEAN,
671 "description", G_TYPE_STRING, "have query result",
673 "res", GST_TYPE_STRUCTURE, gst_structure_new ("value",
674 "type", G_TYPE_GTYPE, G_TYPE_BOOLEAN,
675 "description", G_TYPE_STRING, "query result",
677 /* TODO(ensonic): "buffer-flags" */
679 tr_new_element = gst_tracer_record_new (gst_structure_new (
681 "thread-id", GST_TYPE_STRUCTURE, gst_structure_new ("scope",
682 "type", G_TYPE_GTYPE, G_TYPE_UINT64,
683 "related-to", G_TYPE_STRING, "thread", /* TODO use genum */
685 "ts", GST_TYPE_STRUCTURE, gst_structure_new ("value",
686 "type", G_TYPE_GTYPE, G_TYPE_UINT64,
687 "description", G_TYPE_STRING, "event ts",
689 "ix", GST_TYPE_STRUCTURE, gst_structure_new ("scope",
690 "type", G_TYPE_GTYPE, G_TYPE_UINT,
691 "related-to", G_TYPE_STRING, "element", /* TODO: use genum */
693 "parent-ix", GST_TYPE_STRUCTURE, gst_structure_new ("scope",
694 "type", G_TYPE_GTYPE, G_TYPE_UINT,
695 "related-to", G_TYPE_STRING, "element", /* TODO: use genum */
697 "name", GST_TYPE_STRUCTURE, gst_structure_new ("value",
698 "type", G_TYPE_GTYPE, G_TYPE_STRING,
699 "description", G_TYPE_STRING, "name of the element",
700 "flags", G_TYPE_STRING, "", /* TODO: use gflags */
702 "type", GST_TYPE_STRUCTURE, gst_structure_new ("value",
703 "type", G_TYPE_GTYPE, G_TYPE_STRING,
704 "description", G_TYPE_STRING, "type name of the element",
705 "flags", G_TYPE_STRING, "", /* TODO: use gflags */
707 "is-bin", GST_TYPE_STRUCTURE, gst_structure_new ("value",
708 "type", G_TYPE_GTYPE, G_TYPE_BOOLEAN,
709 "description", G_TYPE_STRING, "is element a bin",
712 tr_new_pad = gst_tracer_record_new (gst_structure_new ("new-pad.class",
713 "thread-id", GST_TYPE_STRUCTURE, gst_structure_new ("scope",
714 "type", G_TYPE_GTYPE, G_TYPE_UINT64,
715 "related-to", G_TYPE_STRING, "thread", /* TODO use genum */
717 "ix", GST_TYPE_STRUCTURE, gst_structure_new ("scope",
718 "type", G_TYPE_GTYPE, G_TYPE_UINT,
719 "related-to", G_TYPE_STRING, "pad", /* TODO: use genum */
721 "parent-ix", GST_TYPE_STRUCTURE, gst_structure_new ("scope",
722 "type", G_TYPE_GTYPE, G_TYPE_UINT,
723 "related-to", G_TYPE_STRING, "element", /* TODO: use genum */
725 "name", GST_TYPE_STRUCTURE, gst_structure_new ("value",
726 "type", G_TYPE_GTYPE, G_TYPE_STRING,
727 "description", G_TYPE_STRING, "name of the pad",
728 "flags", G_TYPE_STRING, "", /* TODO: use gflags */
730 "type", GST_TYPE_STRUCTURE, gst_structure_new ("value",
731 "type", G_TYPE_GTYPE, G_TYPE_STRING,
732 "description", G_TYPE_STRING, "type name of the pad",
733 "flags", G_TYPE_STRING, "", /* TODO: use gflags */
735 "is-ghostpad", GST_TYPE_STRUCTURE, gst_structure_new ("value",
736 "type", G_TYPE_GTYPE, G_TYPE_BOOLEAN,
737 "description", G_TYPE_STRING, "is pad a ghostpad",
739 "pad-direction", GST_TYPE_STRUCTURE, gst_structure_new ("value",
740 "type", G_TYPE_GTYPE, GST_TYPE_PAD_DIRECTION,
741 "description", G_TYPE_STRING, "ipad direction",
748 gst_stats_tracer_init (GstStatsTracer * self)
750 GstTracer *tracer = GST_TRACER (self);
752 gst_tracing_register_hook (tracer, "pad-push-pre",
753 G_CALLBACK (do_push_buffer_pre));
754 gst_tracing_register_hook (tracer, "pad-push-post",
755 G_CALLBACK (do_push_buffer_post));
756 gst_tracing_register_hook (tracer, "pad-push-list-pre",
757 G_CALLBACK (do_push_buffer_list_pre));
758 gst_tracing_register_hook (tracer, "pad-push-list-post",
759 G_CALLBACK (do_push_buffer_list_post));
760 gst_tracing_register_hook (tracer, "pad-pull-range-pre",
761 G_CALLBACK (do_pull_range_pre));
762 gst_tracing_register_hook (tracer, "pad-pull-range-post",
763 G_CALLBACK (do_pull_range_post));
764 gst_tracing_register_hook (tracer, "pad-push-event-pre",
765 G_CALLBACK (do_push_event_pre));
766 gst_tracing_register_hook (tracer, "element-new",
767 G_CALLBACK (do_element_new));
768 gst_tracing_register_hook (tracer, "element-post-message-pre",
769 G_CALLBACK (do_post_message_pre));
770 gst_tracing_register_hook (tracer, "element-query-pre",
771 G_CALLBACK (do_element_query_pre));
772 gst_tracing_register_hook (tracer, "pad-query-pre",
773 G_CALLBACK (do_query_pre));
774 gst_tracing_register_hook (tracer, "pad-query-post",
775 G_CALLBACK (do_query_post));