mirror of
https://gitlab.freedesktop.org/gstreamer/gst-plugins-rs.git
synced 2024-09-27 14:30:27 +00:00
Run C code through gst-indent
This commit is contained in:
parent
31fd26b982
commit
8b313a752a
2 changed files with 55 additions and 45 deletions
44
src/rssink.c
44
src/rssink.c
|
@ -22,27 +22,28 @@
|
||||||
#include <string.h>
|
#include <string.h>
|
||||||
#include <stdint.h>
|
#include <stdint.h>
|
||||||
|
|
||||||
typedef struct {
|
typedef struct
|
||||||
|
{
|
||||||
gchar *name;
|
gchar *name;
|
||||||
gchar *long_name;
|
gchar *long_name;
|
||||||
gchar *description;
|
gchar *description;
|
||||||
gchar *classification;
|
gchar *classification;
|
||||||
gchar *author;
|
gchar *author;
|
||||||
void * (*create_instance) (void);
|
void *(*create_instance) (void);
|
||||||
gchar **protocols;
|
gchar **protocols;
|
||||||
} ElementData;
|
} ElementData;
|
||||||
static GHashTable *sinks;
|
static GHashTable *sinks;
|
||||||
|
|
||||||
/* Declarations for Rust code */
|
/* Declarations for Rust code */
|
||||||
extern gboolean sinks_register (void *plugin);
|
extern gboolean sinks_register (void *plugin);
|
||||||
extern GstFlowReturn sink_render (void * filesink, void * data, size_t data_len);
|
extern GstFlowReturn sink_render (void *filesink, void *data, size_t data_len);
|
||||||
extern gboolean sink_set_uri (void * filesink, const char *uri);
|
extern gboolean sink_set_uri (void *filesink, const char *uri);
|
||||||
extern char * sink_get_uri (void * filesink);
|
extern char *sink_get_uri (void *filesink);
|
||||||
extern gboolean sink_start (void * filesink);
|
extern gboolean sink_start (void *filesink);
|
||||||
extern gboolean sink_stop (void * filesink);
|
extern gboolean sink_stop (void *filesink);
|
||||||
extern void sink_drop (void * filesink);
|
extern void sink_drop (void *filesink);
|
||||||
|
|
||||||
extern void cstring_drop (void * str);
|
extern void cstring_drop (void *str);
|
||||||
|
|
||||||
GST_DEBUG_CATEGORY_STATIC (gst_rs_sink_debug);
|
GST_DEBUG_CATEGORY_STATIC (gst_rs_sink_debug);
|
||||||
#define GST_CAT_DEFAULT gst_rs_sink_debug
|
#define GST_CAT_DEFAULT gst_rs_sink_debug
|
||||||
|
@ -70,7 +71,8 @@ static void gst_rs_sink_get_property (GObject * object, guint prop_id,
|
||||||
static gboolean gst_rs_sink_start (GstBaseSink * basesink);
|
static gboolean gst_rs_sink_start (GstBaseSink * basesink);
|
||||||
static gboolean gst_rs_sink_stop (GstBaseSink * basesink);
|
static gboolean gst_rs_sink_stop (GstBaseSink * basesink);
|
||||||
|
|
||||||
static GstFlowReturn gst_rs_sink_render (GstBaseSink * sink, GstBuffer * buffer);
|
static GstFlowReturn gst_rs_sink_render (GstBaseSink * sink,
|
||||||
|
GstBuffer * buffer);
|
||||||
|
|
||||||
static GObjectClass *parent_class;
|
static GObjectClass *parent_class;
|
||||||
|
|
||||||
|
@ -80,7 +82,8 @@ gst_rs_sink_class_init (GstRsSinkClass * klass)
|
||||||
GObjectClass *gobject_class;
|
GObjectClass *gobject_class;
|
||||||
GstElementClass *gstelement_class;
|
GstElementClass *gstelement_class;
|
||||||
GstBaseSinkClass *gstbasesink_class;
|
GstBaseSinkClass *gstbasesink_class;
|
||||||
ElementData * data = g_hash_table_lookup (sinks, GSIZE_TO_POINTER (G_TYPE_FROM_CLASS (klass)));
|
ElementData *data =
|
||||||
|
g_hash_table_lookup (sinks, GSIZE_TO_POINTER (G_TYPE_FROM_CLASS (klass)));
|
||||||
g_assert (data != NULL);
|
g_assert (data != NULL);
|
||||||
|
|
||||||
gobject_class = G_OBJECT_CLASS (klass);
|
gobject_class = G_OBJECT_CLASS (klass);
|
||||||
|
@ -98,10 +101,7 @@ gst_rs_sink_class_init (GstRsSinkClass * klass)
|
||||||
GST_PARAM_MUTABLE_READY));
|
GST_PARAM_MUTABLE_READY));
|
||||||
|
|
||||||
gst_element_class_set_static_metadata (gstelement_class,
|
gst_element_class_set_static_metadata (gstelement_class,
|
||||||
data->long_name,
|
data->long_name, data->classification, data->description, data->author);
|
||||||
data->classification,
|
|
||||||
data->description,
|
|
||||||
data->author);
|
|
||||||
gst_element_class_add_static_pad_template (gstelement_class, &sink_template);
|
gst_element_class_add_static_pad_template (gstelement_class, &sink_template);
|
||||||
|
|
||||||
gstbasesink_class->start = GST_DEBUG_FUNCPTR (gst_rs_sink_start);
|
gstbasesink_class->start = GST_DEBUG_FUNCPTR (gst_rs_sink_start);
|
||||||
|
@ -112,7 +112,8 @@ gst_rs_sink_class_init (GstRsSinkClass * klass)
|
||||||
static void
|
static void
|
||||||
gst_rs_sink_init (GstRsSink * sink, GstRsSinkClass * klass)
|
gst_rs_sink_init (GstRsSink * sink, GstRsSinkClass * klass)
|
||||||
{
|
{
|
||||||
ElementData * data = g_hash_table_lookup (sinks, GSIZE_TO_POINTER (G_TYPE_FROM_CLASS (klass)));
|
ElementData *data =
|
||||||
|
g_hash_table_lookup (sinks, GSIZE_TO_POINTER (G_TYPE_FROM_CLASS (klass)));
|
||||||
g_assert (data != NULL);
|
g_assert (data != NULL);
|
||||||
|
|
||||||
gst_base_sink_set_sync (GST_BASE_SINK (sink), FALSE);
|
gst_base_sink_set_sync (GST_BASE_SINK (sink), FALSE);
|
||||||
|
@ -153,7 +154,7 @@ gst_rs_sink_get_property (GObject * object, guint prop_id, GValue * value,
|
||||||
GstRsSink *sink = GST_RS_SINK (object);
|
GstRsSink *sink = GST_RS_SINK (object);
|
||||||
|
|
||||||
switch (prop_id) {
|
switch (prop_id) {
|
||||||
case PROP_URI: {
|
case PROP_URI:{
|
||||||
gchar *str = sink_get_uri (sink->instance);
|
gchar *str = sink_get_uri (sink->instance);
|
||||||
g_value_set_string (value, str);
|
g_value_set_string (value, str);
|
||||||
if (str)
|
if (str)
|
||||||
|
@ -207,7 +208,7 @@ gst_rs_sink_uri_get_type (GType type)
|
||||||
static const gchar *const *
|
static const gchar *const *
|
||||||
gst_rs_sink_uri_get_protocols (GType type)
|
gst_rs_sink_uri_get_protocols (GType type)
|
||||||
{
|
{
|
||||||
ElementData * data = g_hash_table_lookup (sinks, GSIZE_TO_POINTER (type));
|
ElementData *data = g_hash_table_lookup (sinks, GSIZE_TO_POINTER (type));
|
||||||
g_assert (data != NULL);
|
g_assert (data != NULL);
|
||||||
|
|
||||||
return (const gchar * const *) data->protocols;
|
return (const gchar * const *) data->protocols;
|
||||||
|
@ -229,7 +230,7 @@ gst_rs_sink_uri_set_uri (GstURIHandler * handler, const gchar * uri,
|
||||||
|
|
||||||
if (!sink_set_uri (sink->instance, uri)) {
|
if (!sink_set_uri (sink->instance, uri)) {
|
||||||
g_set_error (err, GST_URI_ERROR, GST_URI_ERROR_BAD_URI,
|
g_set_error (err, GST_URI_ERROR, GST_URI_ERROR_BAD_URI,
|
||||||
"Can't handle URI '%s'", uri);
|
"Can't handle URI '%s'", uri);
|
||||||
return FALSE;
|
return FALSE;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -259,7 +260,10 @@ gst_rs_sink_plugin_init (GstPlugin * plugin)
|
||||||
}
|
}
|
||||||
|
|
||||||
gboolean
|
gboolean
|
||||||
gst_rs_sink_register (GstPlugin * plugin, const gchar *name, const gchar * long_name, const gchar * description, const gchar * classification, const gchar * author, GstRank rank, void * (*create_instance) (void), const gchar *protocols)
|
gst_rs_sink_register (GstPlugin * plugin, const gchar * name,
|
||||||
|
const gchar * long_name, const gchar * description,
|
||||||
|
const gchar * classification, const gchar * author, GstRank rank,
|
||||||
|
void *(*create_instance) (void), const gchar * protocols)
|
||||||
{
|
{
|
||||||
GTypeInfo type_info = {
|
GTypeInfo type_info = {
|
||||||
sizeof (GstRsSinkClass),
|
sizeof (GstRsSinkClass),
|
||||||
|
|
|
@ -21,29 +21,31 @@
|
||||||
#include <string.h>
|
#include <string.h>
|
||||||
#include <stdint.h>
|
#include <stdint.h>
|
||||||
|
|
||||||
typedef struct {
|
typedef struct
|
||||||
|
{
|
||||||
gchar *long_name;
|
gchar *long_name;
|
||||||
gchar *description;
|
gchar *description;
|
||||||
gchar *classification;
|
gchar *classification;
|
||||||
gchar *author;
|
gchar *author;
|
||||||
void * (*create_instance) (void);
|
void *(*create_instance) (void);
|
||||||
gchar **protocols;
|
gchar **protocols;
|
||||||
} ElementData;
|
} ElementData;
|
||||||
static GHashTable *sources;
|
static GHashTable *sources;
|
||||||
|
|
||||||
/* Declarations for Rust code */
|
/* Declarations for Rust code */
|
||||||
extern gboolean sources_register (void *plugin);
|
extern gboolean sources_register (void *plugin);
|
||||||
extern void source_drop (void * source);
|
extern void source_drop (void *source);
|
||||||
extern GstFlowReturn source_fill (void * source, uint64_t offset, void * data, size_t * data_len);
|
extern GstFlowReturn source_fill (void *source, uint64_t offset, void *data,
|
||||||
extern gboolean source_do_seek (void * source, uint64_t start, uint64_t stop);
|
size_t * data_len);
|
||||||
extern gboolean source_set_uri (void * source, const char *uri);
|
extern gboolean source_do_seek (void *source, uint64_t start, uint64_t stop);
|
||||||
extern char * source_get_uri (void * source);
|
extern gboolean source_set_uri (void *source, const char *uri);
|
||||||
extern uint64_t source_get_size (void * source);
|
extern char *source_get_uri (void *source);
|
||||||
extern gboolean source_is_seekable (void * source);
|
extern uint64_t source_get_size (void *source);
|
||||||
extern gboolean source_start (void * source);
|
extern gboolean source_is_seekable (void *source);
|
||||||
extern gboolean source_stop (void * source);
|
extern gboolean source_start (void *source);
|
||||||
|
extern gboolean source_stop (void *source);
|
||||||
|
|
||||||
extern void cstring_drop (void * str);
|
extern void cstring_drop (void *str);
|
||||||
|
|
||||||
GST_DEBUG_CATEGORY_STATIC (gst_rs_src_debug);
|
GST_DEBUG_CATEGORY_STATIC (gst_rs_src_debug);
|
||||||
#define GST_CAT_DEFAULT gst_rs_src_debug
|
#define GST_CAT_DEFAULT gst_rs_src_debug
|
||||||
|
@ -59,8 +61,7 @@ enum
|
||||||
PROP_URI
|
PROP_URI
|
||||||
};
|
};
|
||||||
|
|
||||||
static void gst_rs_src_uri_handler_init (gpointer g_iface,
|
static void gst_rs_src_uri_handler_init (gpointer g_iface, gpointer iface_data);
|
||||||
gpointer iface_data);
|
|
||||||
|
|
||||||
static void gst_rs_src_finalize (GObject * object);
|
static void gst_rs_src_finalize (GObject * object);
|
||||||
|
|
||||||
|
@ -86,7 +87,8 @@ gst_rs_src_class_init (GstRsSrcClass * klass)
|
||||||
GObjectClass *gobject_class;
|
GObjectClass *gobject_class;
|
||||||
GstElementClass *gstelement_class;
|
GstElementClass *gstelement_class;
|
||||||
GstBaseSrcClass *gstbasesrc_class;
|
GstBaseSrcClass *gstbasesrc_class;
|
||||||
ElementData * data = g_hash_table_lookup (sources, GSIZE_TO_POINTER (G_TYPE_FROM_CLASS (klass)));
|
ElementData *data = g_hash_table_lookup (sources,
|
||||||
|
GSIZE_TO_POINTER (G_TYPE_FROM_CLASS (klass)));
|
||||||
g_assert (data != NULL);
|
g_assert (data != NULL);
|
||||||
|
|
||||||
gobject_class = G_OBJECT_CLASS (klass);
|
gobject_class = G_OBJECT_CLASS (klass);
|
||||||
|
@ -105,10 +107,7 @@ gst_rs_src_class_init (GstRsSrcClass * klass)
|
||||||
gobject_class->finalize = gst_rs_src_finalize;
|
gobject_class->finalize = gst_rs_src_finalize;
|
||||||
|
|
||||||
gst_element_class_set_static_metadata (gstelement_class,
|
gst_element_class_set_static_metadata (gstelement_class,
|
||||||
data->long_name,
|
data->long_name, data->classification, data->description, data->author);
|
||||||
data->classification,
|
|
||||||
data->description,
|
|
||||||
data->author);
|
|
||||||
gst_element_class_add_static_pad_template (gstelement_class, &src_template);
|
gst_element_class_add_static_pad_template (gstelement_class, &src_template);
|
||||||
|
|
||||||
gstbasesrc_class->start = GST_DEBUG_FUNCPTR (gst_rs_src_start);
|
gstbasesrc_class->start = GST_DEBUG_FUNCPTR (gst_rs_src_start);
|
||||||
|
@ -122,7 +121,8 @@ gst_rs_src_class_init (GstRsSrcClass * klass)
|
||||||
static void
|
static void
|
||||||
gst_rs_src_init (GstRsSrc * src, GstRsSrcClass * klass)
|
gst_rs_src_init (GstRsSrc * src, GstRsSrcClass * klass)
|
||||||
{
|
{
|
||||||
ElementData * data = g_hash_table_lookup (sources, GSIZE_TO_POINTER (G_TYPE_FROM_CLASS (klass)));
|
ElementData *data = g_hash_table_lookup (sources,
|
||||||
|
GSIZE_TO_POINTER (G_TYPE_FROM_CLASS (klass)));
|
||||||
g_assert (data != NULL);
|
g_assert (data != NULL);
|
||||||
|
|
||||||
gst_base_src_set_blocksize (GST_BASE_SRC (src), 4096);
|
gst_base_src_set_blocksize (GST_BASE_SRC (src), 4096);
|
||||||
|
@ -163,7 +163,7 @@ gst_rs_src_get_property (GObject * object, guint prop_id, GValue * value,
|
||||||
GstRsSrc *src = GST_RS_SRC (object);
|
GstRsSrc *src = GST_RS_SRC (object);
|
||||||
|
|
||||||
switch (prop_id) {
|
switch (prop_id) {
|
||||||
case PROP_URI: {
|
case PROP_URI:{
|
||||||
gchar *str = source_get_uri (src->instance);
|
gchar *str = source_get_uri (src->instance);
|
||||||
g_value_set_string (value, str);
|
g_value_set_string (value, str);
|
||||||
if (str)
|
if (str)
|
||||||
|
@ -253,7 +253,7 @@ gst_rs_src_uri_get_type (GType type)
|
||||||
static const gchar *const *
|
static const gchar *const *
|
||||||
gst_rs_src_uri_get_protocols (GType type)
|
gst_rs_src_uri_get_protocols (GType type)
|
||||||
{
|
{
|
||||||
ElementData * data = g_hash_table_lookup (sources, GSIZE_TO_POINTER (type));
|
ElementData *data = g_hash_table_lookup (sources, GSIZE_TO_POINTER (type));
|
||||||
g_assert (data != NULL);
|
g_assert (data != NULL);
|
||||||
|
|
||||||
return (const gchar * const *) data->protocols;
|
return (const gchar * const *) data->protocols;
|
||||||
|
@ -275,7 +275,7 @@ gst_rs_src_uri_set_uri (GstURIHandler * handler, const gchar * uri,
|
||||||
|
|
||||||
if (!source_set_uri (src->instance, uri)) {
|
if (!source_set_uri (src->instance, uri)) {
|
||||||
g_set_error (err, GST_URI_ERROR, GST_URI_ERROR_BAD_URI,
|
g_set_error (err, GST_URI_ERROR, GST_URI_ERROR_BAD_URI,
|
||||||
"Can't handle URI '%s'", uri);
|
"Can't handle URI '%s'", uri);
|
||||||
return FALSE;
|
return FALSE;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -305,7 +305,11 @@ gst_rs_source_plugin_init (GstPlugin * plugin)
|
||||||
}
|
}
|
||||||
|
|
||||||
gboolean
|
gboolean
|
||||||
gst_rs_source_register (GstPlugin * plugin, const gchar *name, const gchar * long_name, const gchar * description, const gchar * classification, const gchar * author, GstRank rank, void * (*create_instance) (void), const gchar *protocols, gboolean push_only)
|
gst_rs_source_register (GstPlugin * plugin, const gchar * name,
|
||||||
|
const gchar * long_name, const gchar * description,
|
||||||
|
const gchar * classification, const gchar * author, GstRank rank,
|
||||||
|
void *(*create_instance) (void), const gchar * protocols,
|
||||||
|
gboolean push_only)
|
||||||
{
|
{
|
||||||
GTypeInfo type_info = {
|
GTypeInfo type_info = {
|
||||||
sizeof (GstRsSrcClass),
|
sizeof (GstRsSrcClass),
|
||||||
|
@ -336,7 +340,9 @@ gst_rs_source_register (GstPlugin * plugin, const gchar *name, const gchar * lon
|
||||||
data->protocols = g_strsplit (protocols, ":", -1);
|
data->protocols = g_strsplit (protocols, ":", -1);
|
||||||
|
|
||||||
type_name = g_strconcat ("RsSrc-", name, NULL);
|
type_name = g_strconcat ("RsSrc-", name, NULL);
|
||||||
type = g_type_register_static (push_only ? GST_TYPE_PUSH_SRC : GST_TYPE_BASE_SRC, type_name, &type_info, 0);
|
type =
|
||||||
|
g_type_register_static (push_only ? GST_TYPE_PUSH_SRC : GST_TYPE_BASE_SRC,
|
||||||
|
type_name, &type_info, 0);
|
||||||
g_free (type_name);
|
g_free (type_name);
|
||||||
|
|
||||||
g_type_add_interface_static (type, GST_TYPE_URI_HANDLER, &iface_info);
|
g_type_add_interface_static (type, GST_TYPE_URI_HANDLER, &iface_info);
|
||||||
|
|
Loading…
Reference in a new issue