mirror of
https://gitlab.freedesktop.org/gstreamer/gstreamer.git
synced 2025-02-20 04:56:24 +00:00
acmenc: fix whitespace
Convert to unix newlines, and reindent in some broken places.
This commit is contained in:
Michael Smith
parent
ed72bba6a2
commit
c475d9c012
1 changed files with 576 additions and 553 deletions
|
|
@ -21,7 +21,7 @@
|
|||
|
||||
#ifdef HAVE_CONFIG_H
|
||||
#include "config.h"
|
||||
#endif /*
*/
|
||||
#endif
|
||||
|
||||
#include <windows.h>
|
||||
#include <mmreg.h>
|
||||
|
|
@ -35,8 +35,10 @@
|
|||
* big.
|
||||
*/
|
||||
#define ACM_BUFFER_SIZE (64 * 1024)
|
||||
enum
|
||||
{
ARG_0,
ARG_BITRATE
|
||||
enum
|
||||
{
|
||||
ARG_0,
|
||||
ARG_BITRATE
|
||||
};
|
||||
|
||||
#define DEFAULT_BITRATE 128000
|
||||
|
|
@ -44,30 +46,36 @@
|
|||
#define ACMENC_PARAMS_QDATA g_quark_from_static_string("acmenc-params")
|
||||
|
||||
#define GST_CAT_DEFAULT acmenc_debug
|
||||
GST_DEBUG_CATEGORY_STATIC (acmenc_debug);
|
||||
static GstStaticPadTemplate acmenc_sink_template =
|
||||
GST_STATIC_PAD_TEMPLATE ("sink",
GST_PAD_SINK,
GST_PAD_ALWAYS,
|
||||
GST_STATIC_CAPS ("audio/x-raw-int, "
"depth = (int)16, "
|
||||
"width = (int)16, "
"endianness = (int)" G_STRINGIFY (G_BYTE_ORDER)
|
||||
", "
"signed = (boolean)TRUE, "
"channels = (int) [1,2], "
|
||||
"rate = (int)[1, MAX]")
);
|
||||
static GstStaticPadTemplate acmenc_src_template =
|
||||
GST_STATIC_PAD_TEMPLATE ("src",
GST_PAD_SRC,
GST_PAD_ALWAYS,
|
||||
GST_DEBUG_CATEGORY_STATIC (acmenc_debug);
|
||||
|
||||
static GstStaticPadTemplate acmenc_sink_template =
|
||||
GST_STATIC_PAD_TEMPLATE ("sink",
|
||||
GST_PAD_SINK, GST_PAD_ALWAYS, GST_STATIC_CAPS ("audio/x-raw-int, "
|
||||
"depth = (int)16, "
|
||||
"width = (int)16, "
|
||||
"endianness = (int)" G_STRINGIFY (G_BYTE_ORDER) ", "
|
||||
"signed = (boolean)TRUE, "
|
||||
"channels = (int) [1,2], " "rate = (int)[1, MAX]"));
|
||||
|
||||
static GstStaticPadTemplate acmenc_src_template =
|
||||
GST_STATIC_PAD_TEMPLATE ("src", GST_PAD_SRC, GST_PAD_ALWAYS,
|
||||
GST_STATIC_CAPS_ANY);
|
||||
static GstElementClass *parent_class = NULL;
|
||||
typedef struct _ACMEncClass
|
||||
|
||||
static GstElementClass *parent_class = NULL;
|
||||
typedef struct _ACMEncClass
|
||||
{
|
||||
GstElementClass parent_class;
|
||||
HACMDRIVERID driverId;
|
||||
} ACMEncClass;
|
||||
typedef struct _ACMEnc
|
||||
} ACMEncClass;
|
||||
|
||||
typedef struct _ACMEnc
|
||||
{
|
||||
GstElement parent;
|
||||
GstPad * sinkpad;
|
||||
GstPad * srcpad;
|
||||
GstPad *sinkpad;
|
||||
GstPad *srcpad;
|
||||
gboolean is_setup;
|
||||
WAVEFORMATEX infmt;
|
||||
WAVEFORMATEX * outfmt;
|
||||
WAVEFORMATEX *outfmt;
|
||||
HACMDRIVER driver;
|
||||
HACMSTREAM stream;
|
||||
ACMSTREAMHEADER header;
|
||||
|
|
@ -84,22 +92,25 @@
|
|||
|
||||
/* Set in properties */
|
||||
int selected_bitrate;
|
||||
GstCaps * output_caps;
|
||||
} ACMEnc;
|
||||
typedef struct _ACMEncParams
|
||||
GstCaps *output_caps;
|
||||
} ACMEnc;
|
||||
|
||||
typedef struct _ACMEncParams
|
||||
{
|
||||
HACMDRIVERID driverId;
|
||||
HMODULE dll;
|
||||
gchar * name;
|
||||
} ACMEncParams;
|
||||
static GstCaps *
|
||||
gchar *name;
|
||||
} ACMEncParams;
|
||||
|
||||
static GstCaps *
|
||||
acmenc_caps_from_format (WAVEFORMATEX * fmt)
|
||||
{
|
||||
return gst_riff_create_audio_caps (fmt->wFormatTag, NULL,
|
||||
(gst_riff_strf_auds *) fmt, NULL, NULL, NULL);
|
||||
}
|
||||
}
|
||||
|
||||
gboolean acmenc_set_input_format (ACMEnc * enc, WAVEFORMATEX * infmt)
|
||||
gboolean
|
||||
acmenc_set_input_format (ACMEnc * enc, WAVEFORMATEX * infmt)
|
||||
{
|
||||
infmt->wFormatTag = WAVE_FORMAT_PCM;
|
||||
infmt->nChannels = enc->channels;
|
||||
|
|
@ -109,12 +120,13 @@ acmenc_caps_from_format (WAVEFORMATEX * fmt)
|
|||
infmt->wBitsPerSample = 16;
|
||||
infmt->cbSize = 0;
|
||||
return TRUE;
|
||||
}
|
||||
}
|
||||
|
||||
BOOL CALLBACK acmenc_format_enum (HACMDRIVERID driverId, LPACMFORMATDETAILS fd,
|
||||
BOOL CALLBACK
|
||||
acmenc_format_enum (HACMDRIVERID driverId, LPACMFORMATDETAILS fd,
|
||||
DWORD_PTR dwInstance, DWORD fdwSupport)
|
||||
{
|
||||
ACMEnc * enc = (ACMEnc *) dwInstance;
|
||||
ACMEnc *enc = (ACMEnc *) dwInstance;
|
||||
int oldbrdiff, newbrdiff;
|
||||
gboolean oldmatch, newmatch;
|
||||
if (!enc->outfmt) {
|
||||
|
|
@ -137,8 +149,7 @@ acmenc_caps_from_format (WAVEFORMATEX * fmt)
|
|||
newbrdiff = abs (enc->selected_bitrate - fd->pwfx->nAvgBytesPerSec * 8);
|
||||
oldbrdiff = abs (enc->selected_bitrate - enc->outfmt->nAvgBytesPerSec * 8);
|
||||
if ((newmatch && (!oldmatch || (newbrdiff < oldbrdiff))) ||
|
||||
(!newmatch && !oldmatch && (newbrdiff < oldbrdiff)))
|
||||
{
|
||||
(!newmatch && !oldmatch && (newbrdiff < oldbrdiff))) {
|
||||
g_free (enc->outfmt);
|
||||
enc->outfmt =
|
||||
(WAVEFORMATEX *) g_malloc (fd->pwfx->cbSize + sizeof (WAVEFORMATEX));
|
||||
|
|
@ -147,11 +158,12 @@ acmenc_caps_from_format (WAVEFORMATEX * fmt)
|
|||
|
||||
/* Always return TRUE to continue enumeration */
|
||||
return TRUE;
|
||||
}
|
||||
}
|
||||
|
||||
gboolean acmenc_set_format (ACMEnc * enc)
|
||||
gboolean
|
||||
acmenc_set_format (ACMEnc * enc)
|
||||
{
|
||||
WAVEFORMATEX * in = NULL;
|
||||
WAVEFORMATEX *in = NULL;
|
||||
ACMFORMATDETAILS details;
|
||||
MMRESULT res;
|
||||
int maxSize;
|
||||
|
|
@ -188,12 +200,13 @@ acmenc_caps_from_format (WAVEFORMATEX * fmt)
|
|||
return FALSE;
|
||||
}
|
||||
return TRUE;
|
||||
}
|
||||
static gboolean
|
||||
}
|
||||
|
||||
static gboolean
|
||||
acmenc_setup (ACMEnc * enc)
|
||||
{
|
||||
MMRESULT res;
|
||||
ACMEncClass * encclass = (ACMEncClass *) G_OBJECT_GET_CLASS (enc);
|
||||
ACMEncClass *encclass = (ACMEncClass *) G_OBJECT_GET_CLASS (enc);
|
||||
int destBufferSize;
|
||||
res = acmDriverOpen (&enc->driver, encclass->driverId, 0);
|
||||
if (res) {
|
||||
|
|
@ -235,8 +248,9 @@ acmenc_setup (ACMEnc * enc)
|
|||
}
|
||||
enc->is_setup = TRUE;
|
||||
return TRUE;
|
||||
}
|
||||
static void
|
||||
}
|
||||
|
||||
static void
|
||||
acmenc_teardown (ACMEnc * enc)
|
||||
{
|
||||
if (enc->outfmt) {
|
||||
|
|
@ -263,12 +277,13 @@ acmenc_teardown (ACMEnc * enc)
|
|||
enc->bytes_output = 0;
|
||||
enc->offset = 0;
|
||||
enc->is_setup = FALSE;
|
||||
}
|
||||
static gboolean
|
||||
}
|
||||
|
||||
static gboolean
|
||||
acmenc_sink_setcaps (GstPad * pad, GstCaps * caps)
|
||||
{
|
||||
ACMEnc * enc = (ACMEnc *) GST_PAD_PARENT (pad);
|
||||
GstStructure * structure;
|
||||
ACMEnc *enc = (ACMEnc *) GST_PAD_PARENT (pad);
|
||||
GstStructure *structure;
|
||||
gboolean ret;
|
||||
structure = gst_caps_get_structure (caps, 0);
|
||||
gst_structure_get_int (structure, "channels", &enc->channels);
|
||||
|
|
@ -277,21 +292,21 @@ acmenc_sink_setcaps (GstPad * pad, GstCaps * caps)
|
|||
acmenc_teardown (enc);
|
||||
ret = acmenc_setup (enc);
|
||||
return ret;
|
||||
}
|
||||
static GstFlowReturn
|
||||
}
|
||||
|
||||
static GstFlowReturn
|
||||
acmenc_push_output (ACMEnc * enc)
|
||||
{
|
||||
GstFlowReturn ret = GST_FLOW_OK;
|
||||
if (enc->header.cbDstLengthUsed > 0) {
|
||||
GstBuffer * outbuf =
|
||||
gst_buffer_new_and_alloc (enc->header.cbDstLengthUsed);
|
||||
GstBuffer *outbuf = gst_buffer_new_and_alloc (enc->header.cbDstLengthUsed);
|
||||
memcpy (GST_BUFFER_DATA (outbuf), enc->header.pbDst,
|
||||
enc->header.cbDstLengthUsed);
|
||||
if (enc->outfmt->nAvgBytesPerSec > 0) {
|
||||
|
||||
/* We have a bitrate, so we can create a timestamp, hopefully */
|
||||
GST_BUFFER_TIMESTAMP (outbuf) =
|
||||
gst_util_uint64_scale_int (
enc->bytes_output, GST_SECOND,
|
||||
gst_util_uint64_scale_int (enc->bytes_output, GST_SECOND,
|
||||
enc->outfmt->nAvgBytesPerSec);
|
||||
}
|
||||
enc->bytes_output += enc->header.cbDstLengthUsed;
|
||||
|
|
@ -300,13 +315,14 @@ acmenc_push_output (ACMEnc * enc)
|
|||
ret = gst_pad_push (enc->srcpad, outbuf);
|
||||
}
|
||||
return ret;
|
||||
}
|
||||
static GstFlowReturn
|
||||
}
|
||||
|
||||
static GstFlowReturn
|
||||
acmenc_chain (GstPad * pad, GstBuffer * buf)
|
||||
{
|
||||
MMRESULT res;
|
||||
ACMEnc * enc = (ACMEnc *) GST_PAD_PARENT (pad);
|
||||
guchar * data = GST_BUFFER_DATA (buf);
|
||||
ACMEnc *enc = (ACMEnc *) GST_PAD_PARENT (pad);
|
||||
guchar *data = GST_BUFFER_DATA (buf);
|
||||
gint len = GST_BUFFER_SIZE (buf);
|
||||
int chunklen;
|
||||
GstFlowReturn ret = GST_FLOW_OK;
|
||||
|
|
@ -325,8 +341,7 @@ acmenc_chain (GstPad * pad, GstBuffer * buf)
|
|||
GST_WARNING_OBJECT (enc, "Failed to encode data");
|
||||
break;
|
||||
}
|
||||
if (enc->header.cbSrcLengthUsed > 0)
|
||||
{
|
||||
if (enc->header.cbSrcLengthUsed > 0) {
|
||||
if (enc->header.cbSrcLengthUsed != enc->header.cbSrcLength) {
|
||||
|
||||
/* Only part of input consumed */
|
||||
|
|
@ -344,9 +359,10 @@ acmenc_chain (GstPad * pad, GstBuffer * buf)
|
|||
acmenc_push_output (enc);
|
||||
}
|
||||
return ret;
|
||||
}
|
||||
}
|
||||
|
||||
GstFlowReturn acmenc_finish_stream (ACMEnc * enc)
|
||||
GstFlowReturn
|
||||
acmenc_finish_stream (ACMEnc * enc)
|
||||
{
|
||||
MMRESULT res;
|
||||
GstFlowReturn ret = GST_FLOW_OK;
|
||||
|
|
@ -364,11 +380,12 @@ acmenc_chain (GstPad * pad, GstBuffer * buf)
|
|||
}
|
||||
ret = acmenc_push_output (enc);
|
||||
return ret;
|
||||
}
|
||||
static gboolean
|
||||
}
|
||||
|
||||
static gboolean
|
||||
acmenc_sink_event (GstPad * pad, GstEvent * event)
|
||||
{
|
||||
ACMEnc * enc = (ACMEnc *) GST_PAD_PARENT (pad);
|
||||
ACMEnc *enc = (ACMEnc *) GST_PAD_PARENT (pad);
|
||||
gboolean res;
|
||||
switch (GST_EVENT_TYPE (event)) {
|
||||
case GST_EVENT_EOS:
|
||||
|
|
@ -380,14 +397,15 @@ acmenc_sink_event (GstPad * pad, GstEvent * event)
|
|||
break;
|
||||
}
|
||||
return res;
|
||||
}
|
||||
static void
|
||||
}
|
||||
|
||||
static void
|
||||
acmenc_dispose (GObject * obj)
|
||||
{
|
||||
ACMEnc * enc = (ACMEnc *) obj;
|
||||
ACMEnc *enc = (ACMEnc *) obj;
|
||||
acmenc_teardown (enc);
|
||||
G_OBJECT_CLASS (parent_class)->dispose (obj);
|
||||
}
static void
|
||||
} static void
|
||||
|
||||
acmenc_init (ACMEnc * enc)
|
||||
{
|
||||
|
|
@ -399,15 +417,15 @@ acmenc_init (ACMEnc * enc)
|
|||
gst_pad_set_event_function (enc->sinkpad,
|
||||
GST_DEBUG_FUNCPTR (acmenc_sink_event));
|
||||
gst_element_add_pad (GST_ELEMENT (enc), enc->sinkpad);
|
||||
enc->srcpad =
|
||||
gst_pad_new_from_static_template (&acmenc_src_template, "src");
|
||||
enc->srcpad = gst_pad_new_from_static_template (&acmenc_src_template, "src");
|
||||
gst_element_add_pad (GST_ELEMENT (enc), enc->srcpad);
|
||||
enc->selected_bitrate = DEFAULT_BITRATE;
|
||||
}
static void
|
||||
} static void
|
||||
|
||||
acmenc_set_property (GObject * obj, guint prop_id, const GValue * value,
|
||||
GParamSpec * pspec)
|
||||
{
|
||||
ACMEnc * enc = (ACMEnc *) obj;
|
||||
ACMEnc *enc = (ACMEnc *) obj;
|
||||
switch (prop_id) {
|
||||
case ARG_BITRATE:
|
||||
enc->selected_bitrate = g_value_get_int (value);
|
||||
|
|
@ -415,12 +433,13 @@ acmenc_set_property (GObject * obj, guint prop_id,
const GValue * value,
|
|||
default:
|
||||
G_OBJECT_WARN_INVALID_PROPERTY_ID (obj, prop_id, pspec);
|
||||
}
|
||||
}
|
||||
static void
|
||||
}
|
||||
|
||||
static void
|
||||
acmenc_get_property (GObject * obj, guint prop_id, GValue * value,
|
||||
GParamSpec * pspec)
|
||||
{
|
||||
ACMEnc * enc = (ACMEnc *) obj;
|
||||
ACMEnc *enc = (ACMEnc *) obj;
|
||||
switch (prop_id) {
|
||||
case ARG_BITRATE:
|
||||
g_value_set_int (value, enc->selected_bitrate);
|
||||
|
|
@ -428,11 +447,12 @@ acmenc_get_property (GObject * obj, guint prop_id,
GValue * value,
|
|||
default:
|
||||
G_OBJECT_WARN_INVALID_PROPERTY_ID (obj, prop_id, pspec);
|
||||
}
|
||||
}
|
||||
static void
|
||||
}
|
||||
|
||||
static void
|
||||
acmenc_class_init (ACMEncClass * klass)
|
||||
{
|
||||
GObjectClass * gobjectclass = (GObjectClass *) klass;
|
||||
GObjectClass *gobjectclass = (GObjectClass *) klass;
|
||||
parent_class = (GstElementClass *) g_type_class_peek_parent (klass);
|
||||
gobjectclass->dispose = acmenc_dispose;
|
||||
gobjectclass->set_property = acmenc_set_property;
|
||||
|
|
@ -440,15 +460,15 @@ acmenc_class_init (ACMEncClass * klass)
|
|||
g_object_class_install_property (gobjectclass, ARG_BITRATE,
|
||||
g_param_spec_int ("bitrate", "Bitrate", "Bitrate to encode at (in bps)",
|
||||
0, 1000000, DEFAULT_BITRATE, G_PARAM_READWRITE));
|
||||
}
static void
|
||||
} static void
|
||||
|
||||
acmenc_base_init (ACMEncClass * klass)
|
||||
{
|
||||
GstElementClass * element_class = GST_ELEMENT_CLASS (klass);
|
||||
GstElementClass *element_class = GST_ELEMENT_CLASS (klass);
|
||||
GstElementDetails details;
|
||||
ACMEncParams * params;
|
||||
ACMEncParams *params;
|
||||
ACMDRIVERDETAILS driverdetails;
|
||||
gchar * shortname, *longname;
|
||||
gchar *shortname, *longname;
|
||||
MMRESULT res;
|
||||
gst_element_class_add_pad_template (element_class,
|
||||
gst_static_pad_template_get (&acmenc_sink_template));
|
||||
|
|
@ -464,8 +484,7 @@ acmenc_base_init (ACMEncClass * klass)
|
|||
if (res) {
|
||||
GST_WARNING ("Could not get driver details: %d", res);
|
||||
}
|
||||
shortname =
|
||||
g_utf16_to_utf8 (driverdetails.szShortName, -1, NULL, NULL, NULL);
|
||||
shortname = g_utf16_to_utf8 (driverdetails.szShortName, -1, NULL, NULL, NULL);
|
||||
longname = g_utf16_to_utf8 (driverdetails.szLongName, -1, NULL, NULL, NULL);
|
||||
details.longname = g_strdup_printf ("ACM Encoder: %s", (shortname
|
||||
&& *shortname) ? shortname : params->name);
|
||||
|
|
@ -479,8 +498,9 @@ acmenc_base_init (ACMEncClass * klass)
|
|||
g_free (details.longname);
|
||||
g_free (details.description);
|
||||
klass->driverId = params->driverId;
|
||||
}
|
||||
static ACMEncParams *
|
||||
}
|
||||
|
||||
static ACMEncParams *
|
||||
acmenc_open_driver (wchar_t * filename)
|
||||
{
|
||||
HACMDRIVER driver = NULL;
|
||||
|
|
@ -488,7 +508,7 @@ acmenc_open_driver (wchar_t * filename)
|
|||
HMODULE mod = NULL;
|
||||
FARPROC func;
|
||||
MMRESULT res;
|
||||
ACMEncParams * params;
|
||||
ACMEncParams *params;
|
||||
mod = LoadLibrary (filename);
|
||||
if (!mod) {
|
||||
GST_WARNING ("Failed to load ACM");
|
||||
|
|
@ -509,23 +529,25 @@ acmenc_open_driver (wchar_t * filename)
|
|||
params->dll = mod;
|
||||
params->driverId = driverid;
|
||||
return params;
|
||||
done:
if (driverid)
|
||||
done:if (driverid)
|
||||
acmDriverRemove (driverid, 0);
|
||||
if (mod)
|
||||
FreeLibrary (mod);
|
||||
return NULL;
|
||||
}
|
||||
static gboolean
|
||||
}
|
||||
|
||||
static gboolean
|
||||
acmenc_register_file (GstPlugin * plugin, wchar_t * filename)
|
||||
{
|
||||
ACMEncParams * params;
|
||||
gchar * type_name, *name;
|
||||
ACMEncParams *params;
|
||||
gchar *type_name, *name;
|
||||
GType type;
|
||||
GTypeInfo typeinfo = {
|
||||
sizeof (ACMEncClass),
|
||||
(GBaseInitFunc) acmenc_base_init, NULL,
|
||||
(GClassInitFunc) acmenc_class_init, NULL, NULL, sizeof (ACMEnc),
|
||||
0,
(GInstanceInitFunc) acmenc_init,
};
|
||||
0, (GInstanceInitFunc) acmenc_init,
|
||||
};
|
||||
params = acmenc_open_driver (filename);
|
||||
if (!params)
|
||||
return FALSE;
|
||||
|
|
@ -552,8 +574,9 @@ acmenc_register_file (GstPlugin * plugin, wchar_t * filename)
|
|||
}
|
||||
g_free (type_name);
|
||||
return TRUE;
|
||||
}
|
||||
static gboolean
|
||||
}
|
||||
|
||||
static gboolean
|
||||
acmenc_register (GstPlugin * plugin)
|
||||
{
|
||||
int res;
|
||||
|
|
@ -573,8 +596,7 @@ acmenc_register (GstPlugin * plugin)
|
|||
}
|
||||
|
||||
do {
|
||||
char *filename =
|
||||
g_utf16_to_utf8 (filedata.cFileName, -1, NULL, NULL, NULL);
|
||||
char *filename = g_utf16_to_utf8 (filedata.cFileName, -1, NULL, NULL, NULL);
|
||||
GST_INFO ("Registering ACM filter from file %s", filename);
|
||||
if (acmenc_register_file (plugin, filedata.cFileName))
|
||||
GST_INFO ("Loading filter from ACM '%s' succeeded", filename);
|
||||
|
|
@ -585,8 +607,9 @@ acmenc_register (GstPlugin * plugin)
|
|||
} while (FindNextFile (find, &filedata));
|
||||
FindClose (find);
|
||||
return TRUE;
|
||||
}
|
||||
static gboolean
|
||||
}
|
||||
|
||||
static gboolean
|
||||
plugin_init (GstPlugin * plugin)
|
||||
{
|
||||
gboolean res;
|
||||
|
|
@ -594,8 +617,8 @@ plugin_init (GstPlugin * plugin)
|
|||
GST_INFO ("Registering ACM encoders");
|
||||
res = acmenc_register (plugin);
|
||||
return res;
|
||||
}
|
||||
}
|
||||
|
||||
GST_PLUGIN_DEFINE (GST_VERSION_MAJOR,
GST_VERSION_MINOR,
"acmenc",
|
||||
GST_PLUGIN_DEFINE (GST_VERSION_MAJOR, GST_VERSION_MINOR, "acmenc",
|
||||
"ACM Encoder wrapper", plugin_init, VERSION, "LGPL", "GStreamer",
|
||||
"http://gstreamer.net/")
|
||||
|
|
|
|||
Loading…
Reference in a new issue