<html xmlns:v="urn:schemas-microsoft-com:vml" xmlns:o="urn:schemas-microsoft-com:office:office" xmlns:w="urn:schemas-microsoft-com:office:word" xmlns="http://www.w3.org/TR/REC-html40"> <head> <meta http-equiv=Content-Type content="text/html; charset=us-ascii"> <meta name=Generator content="Microsoft Word 11 (filtered medium)"> <style>  </style> </head> <body lang=DE link=blue vlink=purple> <div class=Section1> Hi,<o:p></o:p> <o:p> </o:p> I try to develop an app using appsrc on gstreamer 1.6.0.<o:p></o:p> The basic of this app is the ‘appsrc_seek.c’ from this example: <a href="http://cgit.freedesktop.org/gstreamer/gst-plugins-base/tree/tests/examples/app/appsrc-seekable.c" title="http://cgit.freedesktop.org/gstreamer/gst-plugins-base/tree/tests/examples/app/appsrc-seekable.c">http://cgit.freedesktop.org/gstreamer/gst-plugins-base/tree/tests/examples/app/appsrc-seekable.c</a>, but with fopen() (not with ‘mmapped file’).<o:p></o:p> <o:p> </o:p> After changing the code, I get this error message: <o:p></o:p> *** Error in `./appsrc_seek': free(): invalid next size (normal): 0x00007f24c4009000 ***<o:p></o:p> <o:p> </o:p> <div style='mso-element:para-border-div;border:none;border-bottom:solid windowtext 1.0pt; padding:0cm 0cm 1.0pt 0cm'> The code is the following:<o:p></o:p> </div> #ifdef HAVE_CONFIG_H<o:p></o:p> #include "config.h"<o:p></o:p> #endif<o:p></o:p> <o:p> </o:p> #include <gst/gst.h><o:p></o:p> <o:p> </o:p> #include <stdio.h><o:p></o:p> #include <string.h><o:p></o:p> #include <stdlib.h><o:p></o:p> #include <sys/types.h><o:p></o:p> #include <unistd.h><o:p></o:p> #include <fcntl.h><o:p></o:p> <o:p> </o:p> GST_DEBUG_CATEGORY (appsrc_playbin_debug);<o:p></o:p> #define GST_CAT_DEFAULT appsrc_playbin_debug<o:p></o:p> <o:p> </o:p> typedef struct _App App;<o:p></o:p> <o:p> </o:p> struct _App<o:p></o:p> {<o:p></o:p> GstElement *playbin;<o:p></o:p> GstElement *appsrc;<o:p></o:p> <o:p> </o:p> GMainLoop *loop;<o:p></o:p> <o:p> </o:p> FILE *file;<o:p></o:p> guint8 *data;<o:p></o:p> long length;<o:p></o:p> guint64 offset;<o:p></o:p> };<o:p></o:p> <o:p> </o:p> App s_app;<o:p></o:p> <o:p> </o:p> #define CHUNK_SIZE 4096<o:p></o:p> <o:p> </o:p> /* This method is called by the need-data signal callback, we feed data into the<o:p></o:p> * appsrc with an arbitrary size.<o:p></o:p> */<o:p></o:p> static void<o:p></o:p> feed_data (GstElement * appsrc, guint size, App * app)<o:p></o:p> {<o:p></o:p> GstBuffer *buffer;<o:p></o:p> guint len;<o:p></o:p> GstFlowReturn ret;<o:p></o:p> <o:p> </o:p> if (app->offset >= app->length) {<o:p></o:p> /* we are EOS, send end-of-stream */<o:p></o:p> g_signal_emit_by_name (app->appsrc, "end-of-stream", &ret);<o:p></o:p> return;<o:p></o:p> }<o:p></o:p> <o:p> </o:p> /* read any amount of data, we are allowed to return less if we are EOS */<o:p></o:p> <o:p> </o:p> len = CHUNK_SIZE;<o:p></o:p> if (app->offset + len > app->length)<o:p></o:p> len = app->length - app->offset;<o:p></o:p> <o:p> </o:p> buffer = gst_buffer_new_allocate (NULL, len, NULL);<o:p></o:p> if(!buffer) printf("Error to allocate memory\n");<o:p></o:p> printf("Buffersize: %" G_GSIZE_FORMAT "\n", gst_buffer_get_size (buffer));<o:p></o:p> fseek(app->file,app->offset,SEEK_SET);<o:p></o:p> fread (buffer,1,len,app->file);<o:p></o:p> <o:p> </o:p> <o:p></o:p> GST_DEBUG ("feed buffer %p, offset %" G_GUINT64_FORMAT "-%u", buffer,<o:p></o:p> app->offset, len);<o:p></o:p> <o:p></o:p> printf("feed buffer %p, offset %"G_GUINT64_FORMAT", len %u \n", buffer, app->offset, len);<o:p></o:p> g_signal_emit_by_name (app->appsrc, "push-buffer", buffer, &ret);<o:p></o:p> gst_buffer_unref (buffer);<o:p></o:p> <o:p> </o:p> app->offset += len;<o:p></o:p> <o:p> </o:p> return;<o:p></o:p> }<o:p></o:p> <o:p> </o:p> /* called when appsrc wants us to return data from a new position with the next<o:p></o:p> * call to push-buffer. */<o:p></o:p> static gboolean<o:p></o:p> seek_data (GstElement * appsrc, guint64 position, App * app)<o:p></o:p> {<o:p></o:p> GST_DEBUG ("seek to offset %" G_GUINT64_FORMAT, position);<o:p></o:p> app->offset = position;<o:p></o:p> <o:p> </o:p> return TRUE;<o:p></o:p> }<o:p></o:p> <o:p> </o:p> static void<o:p></o:p> found_source (GObject * object, GObject * orig, GParamSpec * pspec, App * app)<o:p></o:p> {<o:p></o:p> /* get a handle to the appsrc */<o:p></o:p> g_object_get (orig, pspec->name, &app->appsrc, NULL);<o:p></o:p> <o:p> </o:p> GST_DEBUG ("got appsrc %p", app->appsrc);<o:p></o:p> <o:p> </o:p> g_object_set (app->appsrc, "size", (gint64) app->length, NULL);<o:p></o:p> gst_util_set_object_arg (G_OBJECT (app->appsrc), "stream-type", "seekable");<o:p></o:p> <o:p> </o:p> g_signal_connect (app->appsrc, "need-data", G_CALLBACK (feed_data), app);<o:p></o:p> g_signal_connect (app->appsrc, "seek-data", G_CALLBACK (seek_data), app);<o:p></o:p> }<o:p></o:p> <o:p> </o:p> static gboolean<o:p></o:p> bus_message (GstBus * bus, GstMessage * message, App * app)<o:p></o:p> {<o:p></o:p> GST_DEBUG ("got message %s",<o:p></o:p> gst_message_type_get_name (GST_MESSAGE_TYPE (message)));<o:p></o:p> <o:p> </o:p> switch (GST_MESSAGE_TYPE (message)) {<o:p></o:p> case GST_MESSAGE_ERROR:<o:p></o:p> g_error ("received error");<o:p></o:p> g_main_loop_quit (app->loop);<o:p></o:p> break;<o:p></o:p> case GST_MESSAGE_EOS:<o:p></o:p> g_main_loop_quit (app->loop);<o:p></o:p> break;<o:p></o:p> default:<o:p></o:p> break;<o:p></o:p> }<o:p></o:p> return TRUE;<o:p></o:p> }<o:p></o:p> <o:p> </o:p> <o:p> </o:p> int<o:p></o:p> main (int argc, char *argv[])<o:p></o:p> {<o:p></o:p> GstBus *bus;<o:p></o:p> App *app = &s_app;<o:p></o:p> <o:p> </o:p> gst_init (&argc, &argv);<o:p></o:p> <o:p> </o:p> GST_DEBUG_CATEGORY_INIT (appsrc_playbin_debug, "appsrc-playbin", 0,<o:p></o:p> "appsrc playbin example");<o:p></o:p> <o:p> </o:p> if (argc < 2) {<o:p></o:p> g_print ("usage: %s <filename>\n", argv[0]);<o:p></o:p> return -1;<o:p></o:p> }<o:p></o:p> <o:p> </o:p> app->file = fopen (argv[1], "rb");<o:p></o:p> if (app->file == NULL) {<o:p></o:p> printf("open file error\n");<o:p></o:p> return -2;<o:p></o:p> }<o:p></o:p> <o:p> </o:p> fseek(app->file, 0, SEEK_END);<o:p></o:p> app->length = ftell (app->file);<o:p></o:p> rewind (app->file);<o:p></o:p> app->offset = 0;<o:p></o:p> printf("Filesize: %ld\n", app->length);<o:p></o:p> <o:p> </o:p> /* create a mainloop to get messages */<o:p></o:p> app->loop = g_main_loop_new (NULL, TRUE);<o:p></o:p> <o:p> </o:p> app->playbin = gst_element_factory_make ("playbin", NULL);<o:p></o:p> g_assert (app->playbin);<o:p></o:p> <o:p> </o:p> bus = gst_pipeline_get_bus (GST_PIPELINE (app->playbin));<o:p></o:p> <o:p> </o:p> /* add watch for messages */<o:p></o:p> gst_bus_add_watch (bus, (GstBusFunc) bus_message, app);<o:p></o:p> <o:p> </o:p> /* set to read from appsrc */<o:p></o:p> g_object_set (app->playbin, "uri", "appsrc://", NULL);<o:p></o:p> <o:p> </o:p> /* get notification when the source is created so that we get a handle to it<o:p></o:p> * and can configure it */<o:p></o:p> g_signal_connect (app->playbin, "deep-notify::source",<o:p></o:p> (GCallback) found_source, app);<o:p></o:p> <o:p> </o:p> /* go to playing and wait in a mainloop. */<o:p></o:p> gst_element_set_state (app->playbin, GST_STATE_PLAYING);<o:p></o:p> <o:p> </o:p> /* this mainloop is stopped when we receive an error or EOS */<o:p></o:p> g_main_loop_run (app->loop);<o:p></o:p> <o:p> </o:p> GST_DEBUG ("stopping");<o:p></o:p> <o:p> </o:p> gst_element_set_state (app->playbin, GST_STATE_NULL);<o:p></o:p> <o:p> </o:p> /* free the file */<o:p></o:p> // g_mapped_file_unref (app->file);<o:p></o:p> <o:p> </o:p> gst_object_unref (bus);<o:p></o:p> g_main_loop_unref (app->loop);<o:p></o:p> <o:p> </o:p> return 0;<o:p></o:p> }<o:p></o:p> <div style='mso-element:para-border-div;border:none;border-bottom:solid windowtext 1.0pt; padding:0cm 0cm 1.0pt 0cm'> <o:p> </o:p> </div> <o:p> </o:p> The only code changes are marked in bold.<o:p></o:p> I don’t understand where the fault is.<o:p></o:p> Any idea?<o:p></o:p> <o:p> </o:p> Thanks a lot<o:p></o:p> Bernhard<o:p></o:p> <o:p> </o:p> </div> </body> </html>