How to play audio memory buffer to gstreamer without file?

[wonderjason]

When I have buffer queue ( buffer pointer and buffer size ), I want to use
them to playback.
So, I don't have duration related information.
How to play audio memory buffer to gstreamer without file?

I am able play one audio file to pipeline as below:

static void feed_data (GstElement * appsrc, guint size, App_local * app)
{  
        GstBuffer *buffer;  guint len;  GstFlowReturn ret;  
        buffer = gst_buffer_new ();  
        if (app->offset >= app->length) { /* we are EOS, send end-of-stream
*/
                g_signal_emit_by_name (app->appsrc, "end-of-stream", &ret);
return;  
        }  
       
        /* read any amount of data, we are allowed to return less if we are
EOS */  
        len = CHUNK_SIZE;  
        if (app->offset + len > app->length)
                len = app->length - app->offset;  

        GST_BUFFER_DATA (buffer) = app->data + app->offset;  
        GST_BUFFER_SIZE (buffer) = len;  
        GST_DEBUG ("feed buffer %p, offset %" G_GUINT64_FORMAT "-%u",
buffer, app->offset, len);  
        g_signal_emit_by_name (app->appsrc, "push-buffer", buffer, &ret);  
        gst_buffer_unref (buffer);  app->offset += len;  return;
}

static gboolean seek_data (GstElement * appsrc, guint64 position, App_local
* app)
{  
        GST_DEBUG ("seek to offset %" G_GUINT64_FORMAT, position);  
        app->offset = position;  return TRUE;
}

cb_found_source_local (GObject * object, GObject * orig, GParamSpec * pspec,
App_local * app)
{
        /* get a handle to the appsrc */
        g_object_get (orig, pspec->name, &app->appsrc, NULL);

        g_object_set (app->appsrc, "size", (gint64) app->length, NULL);
        gst_util_set_object_arg (G_OBJECT (app->appsrc), "stream-type",
"seekable");
       
        /* configure the appsrc, we will push a buffer to appsrc when it
needs more data */  
        g_signal_connect (app->appsrc, "need-data", G_CALLBACK (feed_data),
app);  

        g_signal_connect (app->appsrc, "seek-data", G_CALLBACK (seek_data),
app);

        pthread_mutex_lock(&GstGlobalStateLocalFile);
        app->SrcCreated= 1;
        pthread_mutex_unlock(&GstGlobalStateLocalFile);
}

void *CreateGstPipeLocal(void *argv)
{
        char *file_path = "";
        App_local *app = &s_app_local;
        GError *error = NULL;
        GstBus *bus;
        memset (&s_app_local, 0, sizeof (s_app_local));
        app->offset = 0;
        app->buffering = 0;
        app->SrcCreated= 0;
        app->isPlaying =0;

        file_path = (char*)argv;

        app->file = g_mapped_file_new (file_path, FALSE, &error);
        if (error) {
                printf ("failed to open file: %s\n", error->message);
                g_error_free (error);

                pthread_mutex_lock(&GstGlobalStateLocalFile);
                memset(errorMSG_local,0,sizeof(errorMSG_local));
                strncpy(errorMSG_local,"Failed to open
file",sizeof(errorMSG_local));
                errNumber_local = FILE_MESSAGE_ERROR;
                pthread_mutex_unlock(&GstGlobalStateLocalFile);
               
                return NULL;  
        }
        app->length = g_mapped_file_get_length (app->file);
        app->data = (guint8 *) g_mapped_file_get_contents (app->file);
        app->offset = 0;

        /* create a mainloop to get messages */
        app->loop = g_main_loop_new (NULL, TRUE);
        app->playbin = gst_element_factory_make ("playbin2", NULL);
        g_assert (app->playbin);

        /* add watch for messages */
        bus = gst_element_get_bus (app->playbin);
        gst_bus_add_signal_watch (bus);
        g_signal_connect (bus, "message", G_CALLBACK (cb_message_local),
app);

        g_object_set (app->playbin, "uri", "appsrc://", NULL);
        /* get notification when the source is created so that we get a
handle to it
        * and can configure it */
        g_signal_connect (app->playbin, "deep-notify::source",
(GCallback)cb_found_source_local, app);

        /* go to playing and wait in a mainloop. */
        gst_element_set_state (app->playbin, GST_STATE_PAUSED);

                g_isPlaying_local = 0;
        /* this mainloop is stopped when we receive an error or EOS */
        g_main_loop_run (app->loop);
        if (app->playbin) {
                //printf("%s %d Exit local GMain\n", __FUNCTION__,
__LINE__);
                gst_element_set_state (app->playbin, GST_STATE_NULL);
                //printf("%s %d Exit local GMain\n", __FUNCTION__,
__LINE__);
        }else
                printf("%d NULL playbin\n", __LINE__);

        if (app->file !=NULL)
                        g_mapped_file_unref (app->file);

        gst_object_unref (bus);

        g_main_loop_unref (app->loop);
        memset (&s_app_local, 0, sizeof (s_app_local));
        g_isPlaying_local = 0;

        printf("GstPipeLocal END\n");
       
        return NULL;
}



--
View this message in context: http://gstreamer-devel.966125.n4.nabble.com/How-to-play-audio-memory-buffer-to-gstreamer-without-file-tp4683063.html
Sent from the GStreamer-devel mailing list archive at Nabble.com.
_______________________________________________
gstreamer-devel mailing list
[hidden email]
https://lists.freedesktop.org/mailman/listinfo/gstreamer-devel

[Arun Raghavan-4]

Hello,

On Mon, 22 May 2017, at 01:52 PM, wonderjason wrote:
> When I have buffer queue ( buffer pointer and buffer size ), I want to
> use
> them to playback.
> So, I don't have duration related information.
> How to play audio memory buffer to gstreamer without file?
>
> I am able play one audio file to pipeline as below:

Your code seems to be hooked up to supply buffers to an appsrc. What is
the problem you are seeing?

-- Arun
_______________________________________________
gstreamer-devel mailing list
[hidden email]
https://lists.freedesktop.org/mailman/listinfo/gstreamer-devel