diff options
Diffstat (limited to 'gst-vocschnipselssink/src/gstvocschnipselsink.c')
| -rw-r--r-- | gst-vocschnipselssink/src/gstvocschnipselsink.c | 60 |
1 files changed, 37 insertions, 23 deletions
diff --git a/gst-vocschnipselssink/src/gstvocschnipselsink.c b/gst-vocschnipselssink/src/gstvocschnipselsink.c index 47d675d..65caf4d 100644 --- a/gst-vocschnipselssink/src/gstvocschnipselsink.c +++ b/gst-vocschnipselssink/src/gstvocschnipselsink.c @@ -66,6 +66,8 @@ GST_DEBUG_CATEGORY_STATIC (gst_voc_schnipsel_sink_debug); #define GST_CAT_DEFAULT gst_voc_schnipsel_sink_debug +#define DEFAULT_LOCATION "%Y-%m-%d_%H-%M-%S.ts" +#define DEFAULT_FRAMES (4*60*25) /* Filter signals and args */ enum @@ -77,7 +79,8 @@ enum enum { PROP_0, - PROP_SILENT + PROP_LOCATION, + PROP_FRAMES }; /* the capabilities of the inputs and outputs. @@ -127,8 +130,12 @@ gst_voc_schnipsel_sink_class_init (GstVocSchnipselSinkClass * klass) gobject_class->set_property = gst_voc_schnipsel_sink_set_property; gobject_class->get_property = gst_voc_schnipsel_sink_get_property; - g_object_class_install_property (gobject_class, PROP_SILENT, - g_param_spec_boolean ("silent", "Silent", "Produce verbose output ?", + g_object_class_install_property (gobject_class, PROP_LOCATION, + g_param_spec_boolean ("silent", "Silent", "Location of the file to write. Will be processed by strftime, so you can add date/time modifiers. Defaults to " DEFAULT_LOCATION, + FALSE, G_PARAM_READWRITE)); + + g_object_class_install_property (gobject_class, PROP_FRAMES, + g_param_spec_boolean ("silent", "Silent", "Number of frames sfter which a new File will be started. Defaults to 4*60*25 = 6000 Frames", FALSE, G_PARAM_READWRITE)); gst_element_class_set_details_simple(gstelement_class, @@ -147,29 +154,34 @@ gst_voc_schnipsel_sink_class_init (GstVocSchnipselSinkClass * klass) * initialize instance structure */ static void -gst_voc_schnipsel_sink_init (GstVocSchnipselSink * filter) +gst_voc_schnipsel_sink_init (GstVocSchnipselSink * sink) { - filter->sinkpad = gst_pad_new_from_static_template (&sink_factory, "sink"); - gst_pad_set_event_function (filter->sinkpad, + sink->sinkpad = gst_pad_new_from_static_template (&sink_factory, "sink"); + gst_pad_set_event_function (sink->sinkpad, GST_DEBUG_FUNCPTR(gst_voc_schnipsel_sink_sink_event)); - gst_pad_set_chain_function (filter->sinkpad, + gst_pad_set_chain_function (sink->sinkpad, GST_DEBUG_FUNCPTR(gst_voc_schnipsel_sink_chain)); - GST_PAD_SET_PROXY_CAPS (filter->sinkpad); - gst_element_add_pad (GST_ELEMENT (filter), filter->sinkpad); + GST_PAD_SET_PROXY_CAPS (sink->sinkpad); + gst_element_add_pad (GST_ELEMENT (sink), sink->sinkpad); - filter->silent = FALSE; - filter->frames = 0; + sink->location = g_strdup (DEFAULT_LOCATION); + sink->maxframes = DEFAULT_FRAMES; + sink->frames = 0; } static void gst_voc_schnipsel_sink_set_property (GObject * object, guint prop_id, const GValue * value, GParamSpec * pspec) { - GstVocSchnipselSink *filter = GST_VOCSCHNIPSELSINK (object); + GstVocSchnipselSink *sink = GST_VOCSCHNIPSELSINK (object); switch (prop_id) { - case PROP_SILENT: - filter->silent = g_value_get_boolean (value); + case PROP_LOCATION: + g_free (sink->location); + sink->location = g_strdup (g_value_get_string (value)); + break; + case PROP_FRAMES: + sink->maxframes = g_value_get_uint64 (value); break; default: G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec); @@ -181,11 +193,14 @@ static void gst_voc_schnipsel_sink_get_property (GObject * object, guint prop_id, GValue * value, GParamSpec * pspec) { - GstVocSchnipselSink *filter = GST_VOCSCHNIPSELSINK (object); + GstVocSchnipselSink *sink = GST_VOCSCHNIPSELSINK (object); switch (prop_id) { - case PROP_SILENT: - g_value_set_boolean (value, filter->silent); + case PROP_LOCATION: + g_value_set_string (value, sink->location); + break; + case PROP_FRAMES: + g_value_set_uint64 (value, sink->maxframes); break; default: G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec); @@ -274,8 +289,10 @@ gst_voc_schnipsel_sink_chain (GstPad * pad, GstObject * parent, GstBuffer * buf) GstMapInfo map; gst_buffer_map (buf, &map, GST_MAP_READ); - if(++sink->frames > 25 * 5) + if(++sink->frames > sink->maxframes) { + sink->frames = 0; + if (sink->file) { gst_voc_schnipsel_sink_close_file (sink, buf); @@ -344,20 +361,17 @@ gst_voc_schnipsel_sink_write_stream_headers (GstVocSchnipselSink * sink) static gboolean gst_voc_schnipsel_sink_open_next_file (GstVocSchnipselSink * sink) { - // TODO: prefix - // TODO: number of frames - // TODO: location char filename[250]; g_return_val_if_fail (sink->file == NULL, FALSE); - //filename = g_strdup_printf (sink->filename, sink->index); time_t rawtime; struct tm * timeinfo; time (&rawtime); timeinfo = localtime (&rawtime); - strftime(filename, sizeof(filename)/sizeof(*filename), "%Y-%m-%d_%H-%M-%S.ts", timeinfo); + strftime(filename, sizeof(filename)/sizeof(*filename), sink->location, timeinfo); + printf("new file %s\n", filename); sink->file = fopen (filename, "wb"); if (sink->file == NULL) { |