summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
Diffstat
-rw-r--r--gst/siren/gstsirenenc.c214
-rw-r--r--gst/siren/gstsirenenc.h15
2 files changed, 84 insertions, 145 deletions
diff --git a/gst/siren/gstsirenenc.c b/gst/siren/gstsirenenc.c
index 5ffb6641..6dd78b1b 100644
--- a/gst/siren/gstsirenenc.c
+++ b/gst/siren/gstsirenenc.c
@@ -73,15 +73,10 @@ enum
static void gst_siren_enc_dispose (GObject *object);
-static GstFlowReturn gst_siren_enc_transform (GstBaseTransform *trans,
- GstBuffer *inbuf, GstBuffer *outbuf);
-static gboolean gst_siren_enc_transform_size (GstBaseTransform *trans,
- GstPadDirection direction, GstCaps *caps, guint size,
- GstCaps *othercaps, guint *othersize);
-static GstCaps * gst_siren_enc_transform_caps (GstBaseTransform * base,
- GstPadDirection direction, GstCaps * caps);
-static gboolean gst_siren_enc_start (GstBaseTransform *trans);
-static gboolean gst_siren_enc_stop (GstBaseTransform *trans);
+static GstFlowReturn
+gst_siren_enc_chain (GstPad *pad, GstBuffer *buf);
+static GstStateChangeReturn
+gst_siren_change_state (GstElement *element, GstStateChange transition);
static void
@@ -91,8 +86,8 @@ _do_init (GType type)
(sirenenc_debug, "sirenenc", 0, "sirenenc");
}
-GST_BOILERPLATE_FULL (GstSirenEnc, gst_siren_enc, GstBaseTransform,
- GST_TYPE_BASE_TRANSFORM, _do_init);
+GST_BOILERPLATE_FULL (GstSirenEnc, gst_siren_enc, GstElement,
+ GST_TYPE_ELEMENT, _do_init);
static void
gst_siren_enc_base_init (gpointer klass)
@@ -111,25 +106,16 @@ static void
gst_siren_enc_class_init (GstSirenEncClass *klass)
{
GObjectClass *gobject_class;
- GstBaseTransformClass *gstbasetransform_class;
+ GstElementClass *gstelement_class;
gobject_class = (GObjectClass *) klass;
- gstbasetransform_class = (GstBaseTransformClass *) klass;
+ gstelement_class = (GstElementClass *) klass;
GST_DEBUG ("Initializing Class");
gobject_class->dispose = GST_DEBUG_FUNCPTR (gst_siren_enc_dispose);
- gstbasetransform_class->transform =
- GST_DEBUG_FUNCPTR (gst_siren_enc_transform);
- gstbasetransform_class->transform_caps =
- GST_DEBUG_FUNCPTR (gst_siren_enc_transform_caps);
- gstbasetransform_class->transform_size =
- GST_DEBUG_FUNCPTR (gst_siren_enc_transform_size);
- gstbasetransform_class->start =
- GST_DEBUG_FUNCPTR (gst_siren_enc_start);
- gstbasetransform_class->stop =
- GST_DEBUG_FUNCPTR (gst_siren_enc_stop);
+ gstelement_class->change_state = GST_DEBUG_FUNCPTR (gst_siren_change_state);
parent_class = g_type_class_peek_parent (klass);
@@ -141,9 +127,20 @@ gst_siren_enc_init (GstSirenEnc *enc, GstSirenEncClass *klass)
{
GST_DEBUG ("Initializing");
- enc->encoder = NULL;
+ enc->encoder = Siren7_NewEncoder (16000);
enc->adapter = gst_adapter_new ();
+ enc->sinkpad = gst_pad_new_from_static_template (&sinktemplate, "sink");
+ enc->srcpad = gst_pad_new_from_static_template (&srctemplate, "src");
+
+ gst_pad_set_chain_function (enc->sinkpad,
+ GST_DEBUG_FUNCPTR (gst_siren_enc_chain));
+
+ gst_element_add_pad (GST_ELEMENT (enc), enc->sinkpad);
+ gst_element_add_pad (GST_ELEMENT (enc), enc->srcpad);
+
+ enc->srccaps = gst_static_pad_template_get_caps (&srctemplate);
+
GST_DEBUG ("Init done");
}
@@ -163,140 +160,60 @@ gst_siren_enc_dispose (GObject *object)
enc->adapter = NULL;
}
- G_OBJECT_CLASS (parent_class)->dispose (object);
-
- GST_DEBUG ("Dispose done");
-
-}
-
-static gboolean
-gst_siren_enc_start (GstBaseTransform *trans)
-{
- GstSirenEnc *enc = GST_SIREN_ENC (trans);
-
- GST_DEBUG ("Start");
-
- if (enc->encoder) {
- Siren7_CloseEncoder (enc->encoder);
- enc->encoder = NULL;
+ if (enc->srccaps)
+ {
+ gst_caps_unref (enc->srccaps);
+ enc->srccaps = NULL;
}
- enc->encoder = Siren7_NewEncoder (16000);
- gst_adapter_clear (enc->adapter);
-
- return enc->encoder != NULL;
-}
+ G_OBJECT_CLASS (parent_class)->dispose (object);
+ GST_DEBUG ("Dispose done");
-static gboolean
-gst_siren_enc_stop (GstBaseTransform *trans)
-{
- GstSirenEnc *enc = GST_SIREN_ENC (trans);
-
- GST_DEBUG ("Stop");
-
- if (enc->encoder) {
- Siren7_CloseEncoder (enc->encoder);
- enc->encoder = NULL;
- }
- gst_adapter_clear (enc->adapter);
- return TRUE;
-}
-
-
-static gboolean gst_siren_enc_transform_size (GstBaseTransform *trans,
- GstPadDirection direction, GstCaps *caps, guint size,
- GstCaps *othercaps, guint *othersize)
-{
- GstSirenEnc *enc = GST_SIREN_ENC (trans);
- GstStructure *structure;
- const gchar *in_name;
- const gchar *out_name;
-
- if (caps == NULL || othercaps == NULL) {
- GST_WARNING ("caps NULL");
- return FALSE;
- }
-
- structure = gst_caps_get_structure (caps, 0);
- in_name = gst_structure_get_name (structure);
- structure = gst_caps_get_structure (othercaps, 0);
- out_name = gst_structure_get_name (structure);
-
- GST_DEBUG ("Transform size from caps '%s' to '%s'", in_name, out_name);
-
- if (in_name == NULL || out_name == NULL) {
- return FALSE;
- } else if (strcmp (in_name, "audio/x-raw-int") == 0 &&
- strcmp (out_name, "audio/x-siren") == 0 ) {
- size += gst_adapter_available (enc->adapter);
- *othersize = size / 16;
- *othersize -= *othersize % 40;
- if ((size / 16) % 40 > 0)
- *othersize+=40;
- } else if (strcmp (in_name, "audio/x-siren") == 0 &&
- strcmp (out_name, "audio/x-raw-int") == 0 ) {
- *othersize = size * 16;
- *othersize -= *othersize % 640;
- if ((size * 16) % 640 > 0)
- *othersize+= 640;
- } else {
- GST_DEBUG ("Unknown in/out caps");
- return FALSE;
- }
-
- GST_DEBUG ("Transform size %d to %d", size, *othersize);
-
- return TRUE;
-}
-
-static GstCaps * gst_siren_enc_transform_caps (GstBaseTransform * base,
- GstPadDirection direction, GstCaps * caps)
-{
- GST_DEBUG ("Transforming caps");
-
- if (direction == GST_PAD_SRC) {
- return gst_static_pad_template_get_caps (&sinktemplate);
- } else if (direction == GST_PAD_SINK) {
- return gst_static_pad_template_get_caps (&srctemplate);
- }
-
- /* Make gcc happy */
- return NULL;
}
static GstFlowReturn
-gst_siren_enc_transform (GstBaseTransform *trans, GstBuffer *inbuf,
- GstBuffer *outbuf)
+gst_siren_enc_chain (GstPad *pad, GstBuffer *buf)
{
-
- GstSirenEnc *enc = GST_SIREN_ENC (trans);
+ GstSirenEnc *enc = GST_SIREN_ENC (gst_pad_get_parent_element (pad));
GstFlowReturn ret = GST_FLOW_OK;
+ GstBuffer *encoded = NULL;
guint8 *data = NULL;
gint offset = 0;
gint encode_ret = 0;
+ gint size = 0;
GST_DEBUG ("Transform");
if (enc->encoder == NULL) {
- GST_DEBUG ("Siren encoder not set");
+ GST_WARNING ("Siren encoder not set");
return GST_FLOW_WRONG_STATE;
}
if (enc->adapter == NULL) {
- GST_DEBUG ("Adapter not set");
- return GST_FLOW_UNEXPECTED;
+ GST_ERROR ("Adapter not set");
+ return GST_FLOW_ERROR;
}
- gst_buffer_ref (inbuf);
- gst_adapter_push (enc->adapter, inbuf);
+ gst_adapter_push (enc->adapter, buf);
GST_DEBUG ("Received buffer of size %d with adapter of size : %d",
- GST_BUFFER_SIZE (inbuf), gst_adapter_available (enc->adapter));
+ GST_BUFFER_SIZE (buf), gst_adapter_available (enc->adapter));
+
+ size = gst_adapter_available (enc->adapter);
+ size /= 16;
+ size -= size % 40;
+
+ if (size == 0)
+ return GST_FLOW_OK;
+
+ ret = gst_pad_alloc_buffer_and_set_caps (enc->srcpad,
+ GST_BUFFER_OFFSET (buf) / 16, size, enc->srccaps, &encoded);
+ if (ret != GST_FLOW_OK)
+ return ret;
- data = GST_BUFFER_DATA (outbuf);
- offset = 0;
- while(gst_adapter_available (enc->adapter) >= 640 &&
- offset + 40 <= GST_BUFFER_SIZE (outbuf) &&
+ data = GST_BUFFER_DATA (encoded);
+
+ while (gst_adapter_available (enc->adapter) >= 640 &&
ret == GST_FLOW_OK) {
GST_DEBUG ("Encoding frame");
@@ -305,7 +222,7 @@ gst_siren_enc_transform (GstBaseTransform *trans, GstBuffer *inbuf,
(guint8 *)gst_adapter_peek (enc->adapter, 640),
data + offset);
if (encode_ret != 0) {
- GST_DEBUG ("Siren7_EncodeFrame returned %d", encode_ret);
+ GST_ERROR ("Siren7_EncodeFrame returned %d", encode_ret);
ret = GST_FLOW_ERROR;
}
@@ -315,12 +232,37 @@ gst_siren_enc_transform (GstBaseTransform *trans, GstBuffer *inbuf,
GST_DEBUG ("Finished encoding : %d", offset);
- GST_BUFFER_SIZE (outbuf) = offset;
+ GST_BUFFER_SIZE (encoded) = offset;
+
+ ret = gst_pad_push (enc->srcpad, encoded);
return ret;
}
+static GstStateChangeReturn
+gst_siren_change_state (GstElement *element, GstStateChange transition)
+{
+ GstStateChangeReturn ret = GST_STATE_CHANGE_SUCCESS;
+ GstSirenEnc *enc = GST_SIREN_ENC (element);
+
+ ret = GST_ELEMENT_CLASS (parent_class)->change_state (element, transition);
+
+ if (ret == GST_STATE_CHANGE_FAILURE)
+ return ret;
+
+ switch (transition)
+ {
+ case GST_STATE_CHANGE_PAUSED_TO_READY:
+ GST_OBJECT_LOCK (element);
+ gst_adapter_clear (enc->adapter);
+ GST_OBJECT_UNLOCK (element);
+ break;
+ default:
+ break;
+ }
+ return ret;
+}
gboolean
gst_siren_enc_plugin_init (GstPlugin *plugin)
diff --git a/gst/siren/gstsirenenc.h b/gst/siren/gstsirenenc.h
index 1b3937d3..1b404e03 100644
--- a/gst/siren/gstsirenenc.h
+++ b/gst/siren/gstsirenenc.h
@@ -24,7 +24,6 @@
#define __GST_SIREN_ENC_H__
#include <gst/gst.h>
-#include <gst/base/gstbasetransform.h>
#include <gst/base/gstadapter.h>
#include "siren7.h"
@@ -51,22 +50,20 @@ typedef struct _GstSirenEncPrivate GstSirenEncPrivate;
struct _GstSirenEnc
{
- GstBaseTransform parent;
+ GstElement parent;
SirenEncoder encoder;
GstAdapter *adapter;
- /*< private > */
- gpointer _gst_reserved[GST_PADDING];
+ GstPad *srcpad;
+ GstPad *sinkpad;
+
+ GstCaps *srccaps;
};
struct _GstSirenEncClass
{
- GstBaseTransformClass parent_class;
-
-
- /*< private > */
- gpointer _gst_reserved[GST_PADDING];
+ GstElementClass parent_class;
};
GType gst_siren_enc_get_type (void);
generated by cgit v1.2.1 (git 2.18.0) at 2024-11-09 07:17:08 +0000