2 * Copyright (C) 1999,2000 Erik Walthinsen <omega@cse.ogi.edu>
3 * 2000 Wim Taymans <wim@fluendo.com>
7 * This library is free software; you can redistribute it and/or
8 * modify it under the terms of the GNU Library General Public
9 * License as published by the Free Software Foundation; either
10 * version 2 of the License, or (at your option) any later version.
12 * This library is distributed in the hope that it will be useful,
13 * but WITHOUT ANY WARRANTY; without even the implied warranty of
14 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
15 * Library General Public License for more details.
17 * You should have received a copy of the GNU Library General Public
18 * License along with this library; if not, write to the
19 * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
20 * Boston, MA 02111-1307, USA.
23 * SECTION:element-fakesrc
24 * @see_also: #GstFakeSink
26 * The fakesrc element is a multipurpose element that can generate
27 * a wide range of buffers and can operate in various scheduling modes.
29 * It is mostly used as a testing element, one trivial example for testing
30 * basic <application>GStreamer</application> core functionality is:
33 * <title>Example launch line</title>
35 * gst-launch -v fakesrc num-buffers=5 ! fakesink
36 * ]| This pipeline will push 5 empty buffers to the fakesink element and then
40 * Last reviewed on 2008-06-20 (0.10.21)
43 /* FIXME: this ignores basesrc::blocksize property, which could be used as an
44 * alias to ::sizemax (see gst_base_src_get_blocksize()).
54 #include "gstfakesrc.h"
55 #include <gst/gstmarshal.h>
57 static GstStaticPadTemplate srctemplate = GST_STATIC_PAD_TEMPLATE ("src",
62 GST_DEBUG_CATEGORY_STATIC (gst_fake_src_debug);
63 #define GST_CAT_DEFAULT gst_fake_src_debug
65 /* FakeSrc signals and args */
73 #define DEFAULT_OUTPUT FAKE_SRC_FIRST_LAST_LOOP
74 #define DEFAULT_DATA FAKE_SRC_DATA_ALLOCATE
75 #define DEFAULT_SIZETYPE FAKE_SRC_SIZETYPE_EMPTY
76 #define DEFAULT_SIZEMIN 0
77 #define DEFAULT_SIZEMAX 4096
78 #define DEFAULT_FILLTYPE FAKE_SRC_FILLTYPE_ZERO
79 #define DEFAULT_DATARATE 0
80 #define DEFAULT_SYNC FALSE
81 #define DEFAULT_PATTERN NULL
82 #define DEFAULT_EOS FALSE
83 #define DEFAULT_SIGNAL_HANDOFFS FALSE
84 #define DEFAULT_SILENT TRUE
85 #define DEFAULT_DUMP FALSE
86 #define DEFAULT_PARENTSIZE 4096*10
87 #define DEFAULT_CAN_ACTIVATE_PULL TRUE
88 #define DEFAULT_CAN_ACTIVATE_PUSH TRUE
89 #define DEFAULT_FORMAT GST_FORMAT_BYTES
104 PROP_SIGNAL_HANDOFFS,
109 PROP_CAN_ACTIVATE_PULL,
110 PROP_CAN_ACTIVATE_PUSH,
117 #define GST_TYPE_FAKE_SRC_OUTPUT (gst_fake_src_output_get_type())
119 gst_fake_src_output_get_type (void)
121 static GType fakesrc_output_type = 0;
122 static const GEnumValue fakesrc_output[] = {
123 {FAKE_SRC_FIRST_LAST_LOOP, "1", "First-Last loop"},
124 {FAKE_SRC_LAST_FIRST_LOOP, "2", "Last-First loop"},
125 {FAKE_SRC_PING_PONG, "3", "Ping-Pong"},
126 {FAKE_SRC_ORDERED_RANDOM, "4", "Ordered Random"},
127 {FAKE_SRC_RANDOM, "5", "Random"},
128 {FAKE_SRC_PATTERN_LOOP, "6", "Patttern loop"},
129 {FAKE_SRC_PING_PONG_PATTERN, "7", "Ping-Pong Pattern"},
130 {FAKE_SRC_GET_ALWAYS_SUCEEDS, "8", "'_get' Always succeeds"},
134 if (!fakesrc_output_type) {
135 fakesrc_output_type =
136 g_enum_register_static ("GstFakeSrcOutput", fakesrc_output);
138 return fakesrc_output_type;
142 #define GST_TYPE_FAKE_SRC_DATA (gst_fake_src_data_get_type())
144 gst_fake_src_data_get_type (void)
146 static GType fakesrc_data_type = 0;
147 static const GEnumValue fakesrc_data[] = {
148 {FAKE_SRC_DATA_ALLOCATE, "Allocate data", "allocate"},
149 {FAKE_SRC_DATA_SUBBUFFER, "Subbuffer data", "subbuffer"},
153 if (!fakesrc_data_type) {
155 g_enum_register_static ("GstFakeSrcDataType", fakesrc_data);
157 return fakesrc_data_type;
160 #define GST_TYPE_FAKE_SRC_SIZETYPE (gst_fake_src_sizetype_get_type())
162 gst_fake_src_sizetype_get_type (void)
164 static GType fakesrc_sizetype_type = 0;
165 static const GEnumValue fakesrc_sizetype[] = {
166 {FAKE_SRC_SIZETYPE_EMPTY, "Send empty buffers", "empty"},
167 {FAKE_SRC_SIZETYPE_FIXED, "Fixed size buffers (sizemax sized)", "fixed"},
168 {FAKE_SRC_SIZETYPE_RANDOM,
169 "Random sized buffers (sizemin <= size <= sizemax)", "random"},
173 if (!fakesrc_sizetype_type) {
174 fakesrc_sizetype_type =
175 g_enum_register_static ("GstFakeSrcSizeType", fakesrc_sizetype);
177 return fakesrc_sizetype_type;
180 #define GST_TYPE_FAKE_SRC_FILLTYPE (gst_fake_src_filltype_get_type())
182 gst_fake_src_filltype_get_type (void)
184 static GType fakesrc_filltype_type = 0;
185 static const GEnumValue fakesrc_filltype[] = {
186 {FAKE_SRC_FILLTYPE_NOTHING, "Leave data as malloced", "nothing"},
187 {FAKE_SRC_FILLTYPE_ZERO, "Fill buffers with zeros", "zero"},
188 {FAKE_SRC_FILLTYPE_RANDOM, "Fill buffers with random crap", "random"},
189 {FAKE_SRC_FILLTYPE_PATTERN, "Fill buffers with pattern 0x00 -> 0xff",
191 {FAKE_SRC_FILLTYPE_PATTERN_CONT,
192 "Fill buffers with pattern 0x00 -> 0xff that spans buffers",
197 if (!fakesrc_filltype_type) {
198 fakesrc_filltype_type =
199 g_enum_register_static ("GstFakeSrcFillType", fakesrc_filltype);
201 return fakesrc_filltype_type;
205 GST_DEBUG_CATEGORY_INIT (gst_fake_src_debug, "fakesrc", 0, "fakesrc element");
206 #define gst_fake_src_parent_class parent_class
207 G_DEFINE_TYPE_WITH_CODE (GstFakeSrc, gst_fake_src, GST_TYPE_BASE_SRC, _do_init);
209 static void gst_fake_src_finalize (GObject * object);
210 static void gst_fake_src_set_property (GObject * object, guint prop_id,
211 const GValue * value, GParamSpec * pspec);
212 static void gst_fake_src_get_property (GObject * object, guint prop_id,
213 GValue * value, GParamSpec * pspec);
215 static gboolean gst_fake_src_start (GstBaseSrc * basesrc);
216 static gboolean gst_fake_src_stop (GstBaseSrc * basesrc);
217 static gboolean gst_fake_src_is_seekable (GstBaseSrc * basesrc);
219 static gboolean gst_fake_src_event_handler (GstBaseSrc * src, GstEvent * event);
220 static void gst_fake_src_get_times (GstBaseSrc * basesrc, GstBuffer * buffer,
221 GstClockTime * start, GstClockTime * end);
222 static GstFlowReturn gst_fake_src_create (GstBaseSrc * src, guint64 offset,
223 guint length, GstBuffer ** buf);
225 static guint gst_fake_src_signals[LAST_SIGNAL] = { 0 };
227 static GParamSpec *pspec_last_message = NULL;
230 gst_fake_src_class_init (GstFakeSrcClass * klass)
232 GObjectClass *gobject_class;
233 GstElementClass *gstelement_class;
234 GstBaseSrcClass *gstbase_src_class;
236 gobject_class = G_OBJECT_CLASS (klass);
237 gstelement_class = GST_ELEMENT_CLASS (klass);
238 gstbase_src_class = GST_BASE_SRC_CLASS (klass);
240 gobject_class->finalize = gst_fake_src_finalize;
242 gobject_class->set_property = gst_fake_src_set_property;
243 gobject_class->get_property = gst_fake_src_get_property;
246 FIXME: this is not implemented; would make sense once basesrc and fakesrc
247 support multiple pads
248 g_object_class_install_property (gobject_class, PROP_OUTPUT,
249 g_param_spec_enum ("output", "output", "Output method (currently unused)",
250 GST_TYPE_FAKE_SRC_OUTPUT, DEFAULT_OUTPUT, G_PARAM_READWRITE));
252 g_object_class_install_property (gobject_class, PROP_DATA,
253 g_param_spec_enum ("data", "data", "Data allocation method",
254 GST_TYPE_FAKE_SRC_DATA, DEFAULT_DATA,
255 G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
256 g_object_class_install_property (G_OBJECT_CLASS (klass), PROP_SIZETYPE,
257 g_param_spec_enum ("sizetype", "sizetype",
258 "How to determine buffer sizes", GST_TYPE_FAKE_SRC_SIZETYPE,
259 DEFAULT_SIZETYPE, G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
260 g_object_class_install_property (gobject_class, PROP_SIZEMIN,
261 g_param_spec_int ("sizemin", "sizemin", "Minimum buffer size", 0,
262 G_MAXINT, DEFAULT_SIZEMIN,
263 G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
264 g_object_class_install_property (gobject_class, PROP_SIZEMAX,
265 g_param_spec_int ("sizemax", "sizemax", "Maximum buffer size", 0,
266 G_MAXINT, DEFAULT_SIZEMAX,
267 G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
268 g_object_class_install_property (gobject_class, PROP_PARENTSIZE,
269 g_param_spec_int ("parentsize", "parentsize",
270 "Size of parent buffer for sub-buffered allocation", 0, G_MAXINT,
271 DEFAULT_PARENTSIZE, G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
272 g_object_class_install_property (gobject_class, PROP_FILLTYPE,
273 g_param_spec_enum ("filltype", "filltype",
274 "How to fill the buffer, if at all", GST_TYPE_FAKE_SRC_FILLTYPE,
275 DEFAULT_FILLTYPE, G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
276 g_object_class_install_property (gobject_class, PROP_DATARATE,
277 g_param_spec_int ("datarate", "Datarate",
278 "Timestamps buffers with number of bytes per second (0 = none)", 0,
279 G_MAXINT, DEFAULT_DATARATE,
280 G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
281 g_object_class_install_property (gobject_class, PROP_SYNC,
282 g_param_spec_boolean ("sync", "Sync", "Sync to the clock to the datarate",
283 DEFAULT_SYNC, G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
284 g_object_class_install_property (gobject_class, PROP_PATTERN,
285 g_param_spec_string ("pattern", "pattern", "pattern", DEFAULT_PATTERN,
286 G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
287 pspec_last_message = g_param_spec_string ("last-message", "last-message",
288 "The last status message", NULL,
289 G_PARAM_READABLE | G_PARAM_STATIC_STRINGS);
290 g_object_class_install_property (gobject_class, PROP_LAST_MESSAGE,
292 g_object_class_install_property (gobject_class, PROP_SILENT,
293 g_param_spec_boolean ("silent", "Silent",
294 "Don't produce last_message events", DEFAULT_SILENT,
295 G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
296 g_object_class_install_property (gobject_class, PROP_SIGNAL_HANDOFFS,
297 g_param_spec_boolean ("signal-handoffs", "Signal handoffs",
298 "Send a signal before pushing the buffer", DEFAULT_SIGNAL_HANDOFFS,
299 G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
300 g_object_class_install_property (gobject_class, PROP_DUMP,
301 g_param_spec_boolean ("dump", "Dump", "Dump buffer contents to stdout",
302 DEFAULT_DUMP, G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
303 g_object_class_install_property (gobject_class, PROP_CAN_ACTIVATE_PUSH,
304 g_param_spec_boolean ("can-activate-push", "Can activate push",
305 "Can activate in push mode", DEFAULT_CAN_ACTIVATE_PUSH,
306 G_PARAM_READWRITE | G_PARAM_CONSTRUCT | G_PARAM_STATIC_STRINGS));
307 g_object_class_install_property (gobject_class, PROP_CAN_ACTIVATE_PULL,
308 g_param_spec_boolean ("can-activate-pull", "Can activate pull",
309 "Can activate in pull mode", DEFAULT_CAN_ACTIVATE_PULL,
310 G_PARAM_READWRITE | G_PARAM_CONSTRUCT | G_PARAM_STATIC_STRINGS));
311 g_object_class_install_property (gobject_class, PROP_IS_LIVE,
312 g_param_spec_boolean ("is-live", "Is this a live source",
313 "True if the element cannot produce data in PAUSED", FALSE,
314 G_PARAM_READWRITE | G_PARAM_CONSTRUCT | G_PARAM_STATIC_STRINGS));
318 * Set the format of the newsegment events to produce.
322 g_object_class_install_property (gobject_class, PROP_FORMAT,
323 g_param_spec_enum ("format", "Format",
324 "The format of the segment events", GST_TYPE_FORMAT,
325 DEFAULT_FORMAT, G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
328 * GstFakeSrc::handoff:
329 * @fakesrc: the fakesrc instance
330 * @buffer: the buffer that will be pushed
331 * @pad: the pad that will sent it
333 * This signal gets emitted before sending the buffer.
335 gst_fake_src_signals[SIGNAL_HANDOFF] =
336 g_signal_new ("handoff", G_TYPE_FROM_CLASS (klass), G_SIGNAL_RUN_LAST,
337 G_STRUCT_OFFSET (GstFakeSrcClass, handoff), NULL, NULL,
338 gst_marshal_VOID__BOXED_OBJECT, G_TYPE_NONE, 2,
339 GST_TYPE_BUFFER | G_SIGNAL_TYPE_STATIC_SCOPE, GST_TYPE_PAD);
341 gst_element_class_set_details_simple (gstelement_class,
344 "Push empty (no data) buffers around",
345 "Erik Walthinsen <omega@cse.ogi.edu>, " "Wim Taymans <wim@fluendo.com>");
346 gst_element_class_add_pad_template (gstelement_class,
347 gst_static_pad_template_get (&srctemplate));
349 gstbase_src_class->is_seekable = GST_DEBUG_FUNCPTR (gst_fake_src_is_seekable);
350 gstbase_src_class->start = GST_DEBUG_FUNCPTR (gst_fake_src_start);
351 gstbase_src_class->stop = GST_DEBUG_FUNCPTR (gst_fake_src_stop);
352 gstbase_src_class->event = GST_DEBUG_FUNCPTR (gst_fake_src_event_handler);
353 gstbase_src_class->get_times = GST_DEBUG_FUNCPTR (gst_fake_src_get_times);
354 gstbase_src_class->create = GST_DEBUG_FUNCPTR (gst_fake_src_create);
358 gst_fake_src_init (GstFakeSrc * fakesrc)
360 fakesrc->output = FAKE_SRC_FIRST_LAST_LOOP;
361 fakesrc->buffer_count = 0;
362 fakesrc->silent = DEFAULT_SILENT;
363 fakesrc->signal_handoffs = DEFAULT_SIGNAL_HANDOFFS;
364 fakesrc->dump = DEFAULT_DUMP;
365 fakesrc->pattern_byte = 0x00;
366 fakesrc->data = FAKE_SRC_DATA_ALLOCATE;
367 fakesrc->sizetype = FAKE_SRC_SIZETYPE_EMPTY;
368 fakesrc->filltype = FAKE_SRC_FILLTYPE_NOTHING;
369 fakesrc->sizemin = DEFAULT_SIZEMIN;
370 fakesrc->sizemax = DEFAULT_SIZEMAX;
371 fakesrc->parent = NULL;
372 fakesrc->parentsize = DEFAULT_PARENTSIZE;
373 fakesrc->last_message = NULL;
374 fakesrc->datarate = DEFAULT_DATARATE;
375 fakesrc->sync = DEFAULT_SYNC;
376 fakesrc->format = DEFAULT_FORMAT;
380 gst_fake_src_finalize (GObject * object)
384 src = GST_FAKE_SRC (object);
386 g_free (src->last_message);
388 gst_buffer_unref (src->parent);
392 G_OBJECT_CLASS (parent_class)->finalize (object);
396 gst_fake_src_event_handler (GstBaseSrc * basesrc, GstEvent * event)
400 src = GST_FAKE_SRC (basesrc);
403 const GstStructure *s;
407 GST_OBJECT_LOCK (src);
408 g_free (src->last_message);
410 tstr = gst_event_type_get_name (GST_EVENT_TYPE (event));
412 if ((s = gst_event_get_structure (event)))
413 sstr = gst_structure_to_string (s);
415 sstr = g_strdup ("");
418 g_strdup_printf ("event ******* (%s:%s) E (type: %s (%d), %s) %p",
419 GST_DEBUG_PAD_NAME (GST_BASE_SRC_CAST (src)->srcpad),
420 tstr, GST_EVENT_TYPE (event), sstr, event);
422 GST_OBJECT_UNLOCK (src);
424 g_object_notify_by_pspec ((GObject *) src, pspec_last_message);
427 return GST_BASE_SRC_CLASS (parent_class)->event (basesrc, event);
431 gst_fake_src_alloc_parent (GstFakeSrc * src)
435 buf = gst_buffer_new_allocate (NULL, src->parentsize, 0);
438 src->parentoffset = 0;
442 gst_fake_src_set_property (GObject * object, guint prop_id,
443 const GValue * value, GParamSpec * pspec)
448 src = GST_FAKE_SRC (object);
449 basesrc = GST_BASE_SRC (object);
453 g_warning ("not yet implemented");
456 src->data = g_value_get_enum (value);
458 if (src->data == FAKE_SRC_DATA_SUBBUFFER) {
460 gst_fake_src_alloc_parent (src);
463 gst_buffer_unref (src->parent);
469 src->sizetype = g_value_get_enum (value);
472 src->sizemin = g_value_get_int (value);
475 src->sizemax = g_value_get_int (value);
477 case PROP_PARENTSIZE:
478 src->parentsize = g_value_get_int (value);
481 src->filltype = g_value_get_enum (value);
484 src->datarate = g_value_get_int (value);
487 src->sync = g_value_get_boolean (value);
492 src->silent = g_value_get_boolean (value);
494 case PROP_SIGNAL_HANDOFFS:
495 src->signal_handoffs = g_value_get_boolean (value);
498 src->dump = g_value_get_boolean (value);
500 case PROP_CAN_ACTIVATE_PUSH:
501 g_return_if_fail (!GST_OBJECT_FLAG_IS_SET (object,
502 GST_BASE_SRC_FLAG_STARTED));
503 GST_BASE_SRC (src)->can_activate_push = g_value_get_boolean (value);
505 case PROP_CAN_ACTIVATE_PULL:
506 g_return_if_fail (!GST_OBJECT_FLAG_IS_SET (object,
507 GST_BASE_SRC_FLAG_STARTED));
508 src->can_activate_pull = g_value_get_boolean (value);
511 gst_base_src_set_live (basesrc, g_value_get_boolean (value));
514 src->format = g_value_get_enum (value);
517 G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
523 gst_fake_src_get_property (GObject * object, guint prop_id, GValue * value,
529 g_return_if_fail (GST_IS_FAKE_SRC (object));
531 src = GST_FAKE_SRC (object);
532 basesrc = GST_BASE_SRC (object);
536 g_value_set_enum (value, src->output);
539 g_value_set_enum (value, src->data);
542 g_value_set_enum (value, src->sizetype);
545 g_value_set_int (value, src->sizemin);
548 g_value_set_int (value, src->sizemax);
550 case PROP_PARENTSIZE:
551 g_value_set_int (value, src->parentsize);
554 g_value_set_enum (value, src->filltype);
557 g_value_set_int (value, src->datarate);
560 g_value_set_boolean (value, src->sync);
563 g_value_set_string (value, src->pattern);
566 g_value_set_boolean (value, src->silent);
568 case PROP_SIGNAL_HANDOFFS:
569 g_value_set_boolean (value, src->signal_handoffs);
572 g_value_set_boolean (value, src->dump);
574 case PROP_LAST_MESSAGE:
575 GST_OBJECT_LOCK (src);
576 g_value_set_string (value, src->last_message);
577 GST_OBJECT_UNLOCK (src);
579 case PROP_CAN_ACTIVATE_PUSH:
580 g_value_set_boolean (value, GST_BASE_SRC (src)->can_activate_push);
582 case PROP_CAN_ACTIVATE_PULL:
583 g_value_set_boolean (value, src->can_activate_pull);
586 g_value_set_boolean (value, gst_base_src_is_live (basesrc));
589 g_value_set_enum (value, src->format);
592 G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
598 gst_fake_src_prepare_buffer (GstFakeSrc * src, guint8 * data, gsize size)
603 switch (src->filltype) {
604 case FAKE_SRC_FILLTYPE_ZERO:
605 memset (data, 0, size);
607 case FAKE_SRC_FILLTYPE_RANDOM:
612 for (i = size; i; i--) {
613 *ptr++ = g_random_int_range (0, 256);
617 case FAKE_SRC_FILLTYPE_PATTERN:
618 src->pattern_byte = 0x00;
619 case FAKE_SRC_FILLTYPE_PATTERN_CONT:
624 for (i = size; i; i--) {
625 *ptr++ = src->pattern_byte++;
629 case FAKE_SRC_FILLTYPE_NOTHING:
636 gst_fake_src_alloc_buffer (GstFakeSrc * src, guint size)
640 gboolean do_prepare = FALSE;
642 buf = gst_buffer_new ();
645 switch (src->filltype) {
646 case FAKE_SRC_FILLTYPE_NOTHING:
647 data = g_malloc (size);
649 case FAKE_SRC_FILLTYPE_ZERO:
650 data = g_malloc0 (size);
652 case FAKE_SRC_FILLTYPE_RANDOM:
653 case FAKE_SRC_FILLTYPE_PATTERN:
654 case FAKE_SRC_FILLTYPE_PATTERN_CONT:
656 data = g_malloc (size);
661 gst_fake_src_prepare_buffer (src, data, size);
663 gst_buffer_take_memory (buf, -1,
664 gst_memory_new_wrapped (0, data, g_free, size, 0, size));
671 gst_fake_src_get_size (GstFakeSrc * src)
675 switch (src->sizetype) {
676 case FAKE_SRC_SIZETYPE_FIXED:
679 case FAKE_SRC_SIZETYPE_RANDOM:
680 size = g_random_int_range (src->sizemin, src->sizemax);
682 case FAKE_SRC_SIZETYPE_EMPTY:
692 gst_fake_src_create_buffer (GstFakeSrc * src, gsize * bufsize)
695 gsize size = gst_fake_src_get_size (src);
696 gboolean dump = src->dump;
702 case FAKE_SRC_DATA_ALLOCATE:
703 buf = gst_fake_src_alloc_buffer (src, size);
705 case FAKE_SRC_DATA_SUBBUFFER:
706 /* see if we have a parent to subbuffer */
708 gst_fake_src_alloc_parent (src);
709 g_assert (src->parent);
711 /* see if it's large enough */
712 if ((src->parentsize - src->parentoffset) >= size) {
714 gst_buffer_copy_region (src->parent, GST_BUFFER_COPY_ALL,
715 src->parentoffset, size);
716 src->parentoffset += size;
718 /* the parent is useless now */
719 gst_buffer_unref (src->parent);
721 /* try again (this will allocate a new parent) */
722 return gst_fake_src_create_buffer (src, bufsize);
724 gst_buffer_map (buf, &info, GST_MAP_WRITE);
725 gst_fake_src_prepare_buffer (src, info.data, info.size);
726 gst_buffer_unmap (buf, &info);
729 g_warning ("fakesrc: dunno how to allocate buffers !");
730 buf = gst_buffer_new ();
734 gst_buffer_map (buf, &info, GST_MAP_READ);
735 gst_util_dump_mem (info.data, info.size);
736 gst_buffer_unmap (buf, &info);
743 gst_fake_src_get_times (GstBaseSrc * basesrc, GstBuffer * buffer,
744 GstClockTime * start, GstClockTime * end)
748 src = GST_FAKE_SRC (basesrc);
750 /* sync on the timestamp of the buffer if requested. */
752 GstClockTime timestamp, duration;
754 /* first sync on DTS, else use PTS */
755 timestamp = GST_BUFFER_DTS (buffer);
756 if (!GST_CLOCK_TIME_IS_VALID (timestamp))
757 timestamp = GST_BUFFER_PTS (buffer);
759 if (GST_CLOCK_TIME_IS_VALID (timestamp)) {
760 /* get duration to calculate end time */
761 duration = GST_BUFFER_DURATION (buffer);
762 if (GST_CLOCK_TIME_IS_VALID (duration)) {
763 *end = timestamp + duration;
774 gst_fake_src_create (GstBaseSrc * basesrc, guint64 offset, guint length,
782 src = GST_FAKE_SRC (basesrc);
784 buf = gst_fake_src_create_buffer (src, &size);
785 GST_BUFFER_OFFSET (buf) = src->buffer_count++;
787 if (src->datarate > 0) {
788 time = (src->bytes_sent * GST_SECOND) / src->datarate;
790 GST_BUFFER_DURATION (buf) = size * GST_SECOND / src->datarate;
791 } else if (gst_base_src_is_live (basesrc)) {
794 clock = gst_element_get_clock (GST_ELEMENT (src));
797 time = gst_clock_get_time (clock);
798 time -= gst_element_get_base_time (GST_ELEMENT (src));
799 gst_object_unref (clock);
801 /* not an error not to have a clock */
802 time = GST_CLOCK_TIME_NONE;
805 time = GST_CLOCK_TIME_NONE;
808 GST_BUFFER_DTS (buf) = time;
809 GST_BUFFER_PTS (buf) = time;
812 gchar dts_str[64], pts_str[64], dur_str[64];
815 GST_OBJECT_LOCK (src);
816 g_free (src->last_message);
818 if (GST_BUFFER_DTS (buf) != GST_CLOCK_TIME_NONE) {
819 g_snprintf (dts_str, sizeof (dts_str), "%" GST_TIME_FORMAT,
820 GST_TIME_ARGS (GST_BUFFER_DTS (buf)));
822 g_strlcpy (dts_str, "none", sizeof (dts_str));
824 if (GST_BUFFER_PTS (buf) != GST_CLOCK_TIME_NONE) {
825 g_snprintf (pts_str, sizeof (pts_str), "%" GST_TIME_FORMAT,
826 GST_TIME_ARGS (GST_BUFFER_PTS (buf)));
828 g_strlcpy (pts_str, "none", sizeof (pts_str));
830 if (GST_BUFFER_DURATION (buf) != GST_CLOCK_TIME_NONE) {
831 g_snprintf (dur_str, sizeof (dur_str), "%" GST_TIME_FORMAT,
832 GST_TIME_ARGS (GST_BUFFER_DURATION (buf)));
834 g_strlcpy (dur_str, "none", sizeof (dur_str));
838 const char *flag_list[15] = {
839 "", "", "", "", "live", "decode-only", "discont", "resync", "corrupted",
840 "marker", "header", "gap", "droppable", "delta-unit", "in-caps"
843 char *end = flag_str;
845 for (i = 0; i < G_N_ELEMENTS (flag_list); i++) {
846 if (GST_MINI_OBJECT_CAST (buf)->flags & (1 << i)) {
847 strcpy (end, flag_list[i]);
857 g_strdup_printf ("create ******* (%s:%s) (%u bytes, dts: %s, pts:%s"
858 ", duration: %s, offset: %" G_GINT64_FORMAT ", offset_end: %"
859 G_GINT64_FORMAT ", flags: %d %s) %p",
860 GST_DEBUG_PAD_NAME (GST_BASE_SRC_CAST (src)->srcpad), (guint) size,
861 dts_str, pts_str, dur_str, GST_BUFFER_OFFSET (buf),
862 GST_BUFFER_OFFSET_END (buf), GST_MINI_OBJECT_CAST (buf)->flags,
864 GST_OBJECT_UNLOCK (src);
866 g_object_notify_by_pspec ((GObject *) src, pspec_last_message);
869 if (src->signal_handoffs) {
870 GST_LOG_OBJECT (src, "pre handoff emit");
871 g_signal_emit (src, gst_fake_src_signals[SIGNAL_HANDOFF], 0, buf,
873 GST_LOG_OBJECT (src, "post handoff emit");
876 src->bytes_sent += size;
883 gst_fake_src_start (GstBaseSrc * basesrc)
887 src = GST_FAKE_SRC (basesrc);
889 src->buffer_count = 0;
890 src->pattern_byte = 0x00;
893 gst_base_src_set_format (basesrc, src->format);
899 gst_fake_src_stop (GstBaseSrc * basesrc)
903 src = GST_FAKE_SRC (basesrc);
905 GST_OBJECT_LOCK (src);
907 gst_buffer_unref (src->parent);
910 g_free (src->last_message);
911 src->last_message = NULL;
912 GST_OBJECT_UNLOCK (src);
918 gst_fake_src_is_seekable (GstBaseSrc * basesrc)
920 GstFakeSrc *src = GST_FAKE_SRC (basesrc);
922 return src->can_activate_pull;