mirror of
https://gitlab.freedesktop.org/gstreamer/gstreamer.git
synced 2024-09-09 05:38:58 +00:00
Report which format was used for GST_FORMAT_DEFAULT in dvdec
Original commit message from CVS: Report which format was used for GST_FORMAT_DEFAULT in dvdec Add progressreport element for testing.
This commit is contained in:
parent
5a3704a4f0
commit
2d80a4aaa6
5 changed files with 295 additions and 2 deletions
13
ChangeLog
13
ChangeLog
|
@ -1,3 +1,16 @@
|
||||||
|
2004-05-13 Jan Schmidt <thaytan@mad.scientist.com>
|
||||||
|
|
||||||
|
* ext/dv/gstdvdec.c: (gst_dvdec_src_convert)
|
||||||
|
Report which format was used for GST_FORMAT_DEFAULT
|
||||||
|
* gst/debug/Makefile.am:
|
||||||
|
* gst/debug/gstdebug.c: (plugin_init):
|
||||||
|
* gst/debug/progressreport.c: (gst_progressreport_base_init),
|
||||||
|
(gst_progressreport_class_init), (gst_progressreport_init),
|
||||||
|
(gst_progressreport_report), (gst_progressreport_set_property),
|
||||||
|
(gst_progressreport_get_property), (gst_progressreport_chain),
|
||||||
|
(gst_progressreport_plugin_init):
|
||||||
|
Add progressreport element for testing.
|
||||||
|
|
||||||
2004-05-13 Thomas Vander Stichele <thomas at apestaart dot org>
|
2004-05-13 Thomas Vander Stichele <thomas at apestaart dot org>
|
||||||
|
|
||||||
* sys/v4l/gstv4lsrc.c: (gst_v4lsrc_get), (gst_v4lsrc_change_state):
|
* sys/v4l/gstv4lsrc.c: (gst_v4lsrc_get), (gst_v4lsrc_change_state):
|
||||||
|
|
|
@ -155,7 +155,7 @@ gst_dvdec_quality_get_type (void)
|
||||||
{2, "DV_QUALITY_AC_2", "Highest quality mono decoding"},
|
{2, "DV_QUALITY_AC_2", "Highest quality mono decoding"},
|
||||||
{3, "DV_QUALITY_DC|DV_QUALITY_COLOUR", "Fastest colour decoding"},
|
{3, "DV_QUALITY_DC|DV_QUALITY_COLOUR", "Fastest colour decoding"},
|
||||||
{4, "DV_QUALITY_AC_1|DV_QUALITY_COLOUR",
|
{4, "DV_QUALITY_AC_1|DV_QUALITY_COLOUR",
|
||||||
"Colour, using only the first AC coefficient"},
|
"Colour, using only the first AC coefficient"},
|
||||||
{5, "DV_QUALITY_BEST", "Highest quality colour decoding"},
|
{5, "DV_QUALITY_BEST", "Highest quality colour decoding"},
|
||||||
};
|
};
|
||||||
|
|
||||||
|
@ -426,6 +426,7 @@ gst_dvdec_src_convert (GstPad * pad, GstFormat src_format, gint64 src_value,
|
||||||
scale = dvdec->decoder->audio->num_channels * 2;
|
scale = dvdec->decoder->audio->num_channels * 2;
|
||||||
/* fallthrough */
|
/* fallthrough */
|
||||||
case GST_FORMAT_DEFAULT:
|
case GST_FORMAT_DEFAULT:
|
||||||
|
*dest_format = GST_FORMAT_TIME;
|
||||||
if (pad == dvdec->videosrcpad)
|
if (pad == dvdec->videosrcpad)
|
||||||
*dest_value = src_value * dvdec->framerate * scale / GST_SECOND;
|
*dest_value = src_value * dvdec->framerate * scale / GST_SECOND;
|
||||||
else if (pad == dvdec->audiosrcpad)
|
else if (pad == dvdec->audiosrcpad)
|
||||||
|
|
|
@ -15,7 +15,8 @@ libgstdebug_la_SOURCES = \
|
||||||
gstdebug.c \
|
gstdebug.c \
|
||||||
breakmydata.c \
|
breakmydata.c \
|
||||||
negotiation.c \
|
negotiation.c \
|
||||||
gstnavseek.c
|
gstnavseek.c \
|
||||||
|
progressreport.c
|
||||||
|
|
||||||
libgstdebug_la_CFLAGS = $(GST_CFLAGS)
|
libgstdebug_la_CFLAGS = $(GST_CFLAGS)
|
||||||
libgstdebug_la_LDFLAGS = $(GST_PLUGIN_LDFLAGS)
|
libgstdebug_la_LDFLAGS = $(GST_PLUGIN_LDFLAGS)
|
||||||
|
|
|
@ -27,6 +27,7 @@
|
||||||
gboolean gst_break_my_data_plugin_init (GstPlugin * plugin);
|
gboolean gst_break_my_data_plugin_init (GstPlugin * plugin);
|
||||||
gboolean gst_negotiation_plugin_init (GstPlugin * plugin);
|
gboolean gst_negotiation_plugin_init (GstPlugin * plugin);
|
||||||
gboolean gst_navseek_plugin_init (GstPlugin * plugin);
|
gboolean gst_navseek_plugin_init (GstPlugin * plugin);
|
||||||
|
gboolean gst_progressreport_plugin_init (GstPlugin * plugin);
|
||||||
|
|
||||||
static gboolean
|
static gboolean
|
||||||
plugin_init (GstPlugin * plugin)
|
plugin_init (GstPlugin * plugin)
|
||||||
|
@ -34,6 +35,7 @@ plugin_init (GstPlugin * plugin)
|
||||||
gst_break_my_data_plugin_init (plugin);
|
gst_break_my_data_plugin_init (plugin);
|
||||||
gst_negotiation_plugin_init (plugin);
|
gst_negotiation_plugin_init (plugin);
|
||||||
gst_navseek_plugin_init (plugin);
|
gst_navseek_plugin_init (plugin);
|
||||||
|
gst_progressreport_plugin_init (plugin);
|
||||||
|
|
||||||
return TRUE;
|
return TRUE;
|
||||||
}
|
}
|
||||||
|
|
276
gst/debug/progressreport.c
Normal file
276
gst/debug/progressreport.c
Normal file
|
@ -0,0 +1,276 @@
|
||||||
|
/* GStreamer
|
||||||
|
* Copyright (C) <1999> Erik Walthinsen <omega@cse.ogi.edu>
|
||||||
|
* Copyright (C) <2003> David Schleef <ds@schleef.org>
|
||||||
|
* Copyright (C) <2004> Jan Schmidt <thaytan@mad.scientist.com>
|
||||||
|
*
|
||||||
|
* This library is free software; you can redistribute it and/or
|
||||||
|
* modify it under the terms of the GNU Library General Public
|
||||||
|
* License as published by the Free Software Foundation; either
|
||||||
|
* version 2 of the License, or (at your option) any later version.
|
||||||
|
*
|
||||||
|
* This library is distributed in the hope that it will be useful,
|
||||||
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||||
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
||||||
|
* Library General Public License for more details.
|
||||||
|
*
|
||||||
|
* You should have received a copy of the GNU Library General Public
|
||||||
|
* License along with this library; if not, write to the
|
||||||
|
* Free Software Foundation, Inc., 59 Temple Place - Suite 330,
|
||||||
|
* Boston, MA 02111-1307, USA.
|
||||||
|
*/
|
||||||
|
|
||||||
|
#ifdef HAVE_CONFIG_H
|
||||||
|
#include "config.h"
|
||||||
|
#endif
|
||||||
|
|
||||||
|
#include <gst/gst.h>
|
||||||
|
#include <string.h>
|
||||||
|
#include <math.h>
|
||||||
|
#include <time.h>
|
||||||
|
|
||||||
|
#define GST_TYPE_PROGRESSREPORT \
|
||||||
|
(gst_progressreport_get_type())
|
||||||
|
#define GST_PROGRESSREPORT(obj) \
|
||||||
|
(G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_PROGRESSREPORT,GstProgressReport))
|
||||||
|
#define GST_PROGRESSREPORT_CLASS(klass) \
|
||||||
|
(G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_PROGRESSREPORT,GstProgressReportClass))
|
||||||
|
#define GST_IS_PROGRESSREPORT(obj) \
|
||||||
|
(G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_PROGRESSREPORT))
|
||||||
|
#define GST_IS_PROGRESSREPORT_CLASS(obj) \
|
||||||
|
(G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_PROGRESSREPORT))
|
||||||
|
|
||||||
|
typedef struct _GstProgressReport GstProgressReport;
|
||||||
|
typedef struct _GstProgressReportClass GstProgressReportClass;
|
||||||
|
|
||||||
|
struct _GstProgressReport
|
||||||
|
{
|
||||||
|
GstElement element;
|
||||||
|
GstPad *sinkpad;
|
||||||
|
GstPad *srcpad;
|
||||||
|
|
||||||
|
gint update_freq;
|
||||||
|
GTimeVal start_time;
|
||||||
|
GTimeVal last_report;
|
||||||
|
};
|
||||||
|
|
||||||
|
struct _GstProgressReportClass
|
||||||
|
{
|
||||||
|
GstElementClass parent_class;
|
||||||
|
};
|
||||||
|
|
||||||
|
/* GstProgressReport signals and args */
|
||||||
|
enum
|
||||||
|
{
|
||||||
|
/* FILL ME */
|
||||||
|
LAST_SIGNAL
|
||||||
|
};
|
||||||
|
|
||||||
|
enum
|
||||||
|
{
|
||||||
|
ARG_0,
|
||||||
|
ARG_UPDATE_FREQ
|
||||||
|
/* FILL ME */
|
||||||
|
};
|
||||||
|
|
||||||
|
GstStaticPadTemplate progressreport_src_template =
|
||||||
|
GST_STATIC_PAD_TEMPLATE ("src",
|
||||||
|
GST_PAD_SRC,
|
||||||
|
GST_PAD_ALWAYS,
|
||||||
|
GST_STATIC_CAPS_ANY);
|
||||||
|
|
||||||
|
GstStaticPadTemplate progressreport_sink_template =
|
||||||
|
GST_STATIC_PAD_TEMPLATE ("sink",
|
||||||
|
GST_PAD_SINK,
|
||||||
|
GST_PAD_ALWAYS,
|
||||||
|
GST_STATIC_CAPS_ANY);
|
||||||
|
|
||||||
|
static void gst_progressreport_set_property (GObject * object, guint prop_id,
|
||||||
|
const GValue * value, GParamSpec * pspec);
|
||||||
|
static void gst_progressreport_get_property (GObject * object, guint prop_id,
|
||||||
|
GValue * value, GParamSpec * pspec);
|
||||||
|
static void gst_progressreport_chain (GstPad * pad, GstData * _data);
|
||||||
|
|
||||||
|
GST_BOILERPLATE (GstProgressReport, gst_progressreport, GstElement,
|
||||||
|
GST_TYPE_ELEMENT);
|
||||||
|
|
||||||
|
static void
|
||||||
|
gst_progressreport_base_init (gpointer g_class)
|
||||||
|
{
|
||||||
|
static GstElementDetails progressreport_details =
|
||||||
|
GST_ELEMENT_DETAILS ("Progress Report",
|
||||||
|
"Testing",
|
||||||
|
"Periodically query and report on processing progress",
|
||||||
|
"Jan Schmidt <thaytan@mad.scientist.com>");
|
||||||
|
GstElementClass *element_class = GST_ELEMENT_CLASS (g_class);
|
||||||
|
|
||||||
|
gst_element_class_add_pad_template (element_class,
|
||||||
|
gst_static_pad_template_get (&progressreport_sink_template));
|
||||||
|
gst_element_class_add_pad_template (element_class,
|
||||||
|
gst_static_pad_template_get (&progressreport_src_template));
|
||||||
|
|
||||||
|
gst_element_class_set_details (element_class, &progressreport_details);
|
||||||
|
}
|
||||||
|
|
||||||
|
static void
|
||||||
|
gst_progressreport_class_init (GstProgressReportClass * g_class)
|
||||||
|
{
|
||||||
|
GObjectClass *gobject_class;
|
||||||
|
|
||||||
|
gobject_class = G_OBJECT_CLASS (g_class);
|
||||||
|
|
||||||
|
g_object_class_install_property (G_OBJECT_CLASS (g_class),
|
||||||
|
ARG_UPDATE_FREQ, g_param_spec_int ("update-freq", "Update Frequency",
|
||||||
|
"Number of seconds between reports when data is flowing", 1, G_MAXINT,
|
||||||
|
5, G_PARAM_READWRITE));
|
||||||
|
|
||||||
|
gobject_class->set_property = gst_progressreport_set_property;
|
||||||
|
gobject_class->get_property = gst_progressreport_get_property;
|
||||||
|
}
|
||||||
|
|
||||||
|
static void
|
||||||
|
gst_progressreport_init (GstProgressReport * instance)
|
||||||
|
{
|
||||||
|
GstProgressReport *progressreport = GST_PROGRESSREPORT (instance);
|
||||||
|
|
||||||
|
progressreport->sinkpad =
|
||||||
|
gst_pad_new_from_template (gst_static_pad_template_get
|
||||||
|
(&progressreport_sink_template), "sink");
|
||||||
|
gst_element_add_pad (GST_ELEMENT (progressreport), progressreport->sinkpad);
|
||||||
|
gst_pad_set_chain_function (progressreport->sinkpad,
|
||||||
|
gst_progressreport_chain);
|
||||||
|
gst_pad_set_link_function (progressreport->sinkpad, gst_pad_proxy_pad_link);
|
||||||
|
gst_pad_set_getcaps_function (progressreport->sinkpad, gst_pad_proxy_getcaps);
|
||||||
|
|
||||||
|
progressreport->srcpad =
|
||||||
|
gst_pad_new_from_template (gst_static_pad_template_get
|
||||||
|
(&progressreport_src_template), "src");
|
||||||
|
gst_element_add_pad (GST_ELEMENT (progressreport), progressreport->srcpad);
|
||||||
|
gst_pad_set_link_function (progressreport->srcpad, gst_pad_proxy_pad_link);
|
||||||
|
gst_pad_set_getcaps_function (progressreport->srcpad, gst_pad_proxy_getcaps);
|
||||||
|
|
||||||
|
g_get_current_time (&(progressreport->last_report));
|
||||||
|
progressreport->start_time = progressreport->last_report;
|
||||||
|
progressreport->update_freq = 5;
|
||||||
|
}
|
||||||
|
|
||||||
|
static void
|
||||||
|
gst_progressreport_report (GstProgressReport * progressreport,
|
||||||
|
GTimeVal cur_time)
|
||||||
|
{
|
||||||
|
/* Query for the current time then attempt to set to time + offset */
|
||||||
|
gint64 cur_progress;
|
||||||
|
gint64 total_progress;
|
||||||
|
GstFormat peer_format = GST_FORMAT_DEFAULT;
|
||||||
|
gint hh, mm, ss;
|
||||||
|
glong run_time = cur_time.tv_sec - progressreport->start_time.tv_sec;
|
||||||
|
|
||||||
|
hh = (run_time / 3600) % 100;
|
||||||
|
mm = (run_time / 60) % 60;
|
||||||
|
ss = (run_time % 60);
|
||||||
|
|
||||||
|
if (gst_pad_query (gst_pad_get_peer (progressreport->sinkpad),
|
||||||
|
GST_QUERY_POSITION, &peer_format, &cur_progress)) {
|
||||||
|
GstFormat peer_format2 = peer_format;
|
||||||
|
gchar *format_name = NULL;
|
||||||
|
|
||||||
|
switch (peer_format) {
|
||||||
|
case GST_FORMAT_BYTES:
|
||||||
|
format_name = "bytes";
|
||||||
|
break;
|
||||||
|
case GST_FORMAT_TIME:
|
||||||
|
format_name = "seconds";
|
||||||
|
cur_progress /= GST_SECOND;
|
||||||
|
total_progress /= GST_SECOND;
|
||||||
|
break;
|
||||||
|
case GST_FORMAT_BUFFERS:
|
||||||
|
format_name = "buffers";
|
||||||
|
break;
|
||||||
|
case GST_FORMAT_PERCENT:
|
||||||
|
format_name = "percent";
|
||||||
|
break;
|
||||||
|
default:
|
||||||
|
format_name = "unknown";
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
|
||||||
|
if ((gst_pad_query (gst_pad_get_peer (progressreport->sinkpad),
|
||||||
|
GST_QUERY_TOTAL, &peer_format2, &total_progress)) &&
|
||||||
|
(peer_format == peer_format2)) {
|
||||||
|
g_print ("%s (%2d:%2d:%2d): %lld / %lld %s (%3.2g %%)\n",
|
||||||
|
gst_object_get_name (GST_OBJECT (progressreport)), hh, mm, ss,
|
||||||
|
cur_progress, total_progress, format_name,
|
||||||
|
((gdouble) (cur_progress)) / total_progress * 100);
|
||||||
|
} else {
|
||||||
|
g_print ("%s (%2d:%2d:%2d): %lld %s\n",
|
||||||
|
gst_object_get_name (GST_OBJECT (progressreport)), hh, mm, ss,
|
||||||
|
cur_progress, format_name);
|
||||||
|
}
|
||||||
|
} else {
|
||||||
|
g_print ("%s (%2d:%2d:%2d): Could not query current position.\n",
|
||||||
|
gst_object_get_name (GST_OBJECT (progressreport)), hh, mm, ss);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
static void
|
||||||
|
gst_progressreport_set_property (GObject * object, guint prop_id,
|
||||||
|
const GValue * value, GParamSpec * pspec)
|
||||||
|
{
|
||||||
|
GstProgressReport *src;
|
||||||
|
|
||||||
|
g_return_if_fail (GST_IS_PROGRESSREPORT (object));
|
||||||
|
src = GST_PROGRESSREPORT (object);
|
||||||
|
|
||||||
|
switch (prop_id) {
|
||||||
|
case ARG_UPDATE_FREQ:
|
||||||
|
src->update_freq = g_value_get_int (value);
|
||||||
|
break;
|
||||||
|
default:
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
static void
|
||||||
|
gst_progressreport_get_property (GObject * object, guint prop_id,
|
||||||
|
GValue * value, GParamSpec * pspec)
|
||||||
|
{
|
||||||
|
GstProgressReport *src;
|
||||||
|
|
||||||
|
g_return_if_fail (GST_IS_PROGRESSREPORT (object));
|
||||||
|
src = GST_PROGRESSREPORT (object);
|
||||||
|
|
||||||
|
switch (prop_id) {
|
||||||
|
case ARG_UPDATE_FREQ:
|
||||||
|
g_value_set_int (value, src->update_freq);
|
||||||
|
break;
|
||||||
|
default:
|
||||||
|
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
static void
|
||||||
|
gst_progressreport_chain (GstPad * pad, GstData * _data)
|
||||||
|
{
|
||||||
|
GstProgressReport *progressreport;
|
||||||
|
GTimeVal cur_time;
|
||||||
|
|
||||||
|
g_get_current_time (&cur_time);
|
||||||
|
|
||||||
|
progressreport = GST_PROGRESSREPORT (gst_pad_get_parent (pad));
|
||||||
|
|
||||||
|
/* Check if update_freq seconds have passed since the last update */
|
||||||
|
if ((cur_time.tv_sec - progressreport->last_report.tv_sec) >=
|
||||||
|
progressreport->update_freq) {
|
||||||
|
gst_progressreport_report (progressreport, cur_time);
|
||||||
|
progressreport->last_report = cur_time;
|
||||||
|
}
|
||||||
|
|
||||||
|
gst_pad_push (progressreport->srcpad, _data);
|
||||||
|
}
|
||||||
|
|
||||||
|
gboolean
|
||||||
|
gst_progressreport_plugin_init (GstPlugin * plugin)
|
||||||
|
{
|
||||||
|
return gst_element_register (plugin, "progressreport", GST_RANK_NONE,
|
||||||
|
GST_TYPE_PROGRESSREPORT);
|
||||||
|
}
|
Loading…
Reference in a new issue