From 482bff1ce4f603930be401dbe470d86b6615972b Mon Sep 17 00:00:00 2001 From: Xavi Artigas Date: Tue, 19 Jun 2012 17:59:37 +0200 Subject: [PATCH] Added playback tutorial 3 --- gst-sdk/tutorials/playback-tutorial-3.c | 153 +++++++++++++++++++++ .../playback-tutorial-3.vcxproj | 95 +++++++++++++ .../playback-tutorial-3.vcxproj.filters | 6 + gst-sdk/tutorials/vs2010/tutorials.sln | 10 ++ 4 files changed, 264 insertions(+) create mode 100644 gst-sdk/tutorials/playback-tutorial-3.c create mode 100644 gst-sdk/tutorials/vs2010/playback-tutorial-3/playback-tutorial-3.vcxproj create mode 100644 gst-sdk/tutorials/vs2010/playback-tutorial-3/playback-tutorial-3.vcxproj.filters diff --git a/gst-sdk/tutorials/playback-tutorial-3.c b/gst-sdk/tutorials/playback-tutorial-3.c new file mode 100644 index 0000000..f48bca3 --- /dev/null +++ b/gst-sdk/tutorials/playback-tutorial-3.c @@ -0,0 +1,153 @@ +#include +#include + +#define CHUNK_SIZE 1024 /* Amount of bytes we are sending in each buffer */ +#define SAMPLE_RATE 44100 /* Samples per second we are sending */ +#define AUDIO_CAPS "audio/x-raw-int,channels=1,rate=%d,signed=(boolean)true,width=16,depth=16,endianness=BYTE_ORDER" + +/* Structure to contain all our information, so we can pass it to callbacks */ +typedef struct _CustomData { + GstElement *pipeline; + GstElement *app_source; + + guint64 num_samples; /* Number of samples generated so far (for timestamp generation) */ + gfloat a, b, c, d; /* For waveform generation */ + + guint sourceid; /* To control the GSource */ + + GMainLoop *main_loop; /* GLib's Main Loop */ +} CustomData; + +/* This method is called by the idle GSource in the mainloop, to feed CHUNK_SIZE bytes into appsrc. + * The ide handler is added to the mainloop when appsrc requests us to start sending data (need-data signal) + * and is removed when appsrc has enough data (enough-data signal). + */ +static gboolean push_data (CustomData *data) { + GstBuffer *buffer; + GstFlowReturn ret; + int i; + gint16 *raw; + gint num_samples = CHUNK_SIZE / 2; /* Because each sample is 16 bits */ + gfloat freq; + + /* Create a new empty buffer */ + buffer = gst_buffer_new_and_alloc (CHUNK_SIZE); + + /* Set its timestamp and duration */ + GST_BUFFER_TIMESTAMP (buffer) = gst_util_uint64_scale (data->num_samples, GST_SECOND, SAMPLE_RATE); + GST_BUFFER_DURATION (buffer) = gst_util_uint64_scale (CHUNK_SIZE, GST_SECOND, SAMPLE_RATE); + + /* Generate some psychodelic waveforms */ + raw = (gint16 *)GST_BUFFER_DATA (buffer); + data->c += data->d; + data->d -= data->c / 1000; + freq = 1100 + 1000 * data->d; + for (i = 0; i < num_samples; i++) { + data->a += data->b; + data->b -= data->a / freq; + raw[i] = (gint16)(500 * data->a); + } + data->num_samples += num_samples; + + /* Push the buffer into the appsrc */ + g_signal_emit_by_name (data->app_source, "push-buffer", buffer, &ret); + + /* Free the buffer now that we are done with it */ + gst_buffer_unref (buffer); + + if (ret != GST_FLOW_OK) { + /* We got some error, stop sending data */ + return FALSE; + } + + return TRUE; +} + +/* This signal callback triggers when appsrc needs data. Here, we add an idle handler + * to the mainloop to start pushing data into the appsrc */ +static void start_feed (GstElement *source, guint size, CustomData *data) { + if (data->sourceid == 0) { + g_print ("Start feeding\n"); + data->sourceid = g_idle_add ((GSourceFunc) push_data, data); + } +} + +/* This callback triggers when appsrc has enough data and we can stop sending. + * We remove the idle handler from the mainloop */ +static void stop_feed (GstElement *source, CustomData *data) { + if (data->sourceid != 0) { + g_print ("Stop feeding\n"); + g_source_remove (data->sourceid); + data->sourceid = 0; + } +} + +/* This function is called when an error message is posted on the bus */ +static void error_cb (GstBus *bus, GstMessage *msg, CustomData *data) { + GError *err; + gchar *debug_info; + + /* Print error details on the screen */ + gst_message_parse_error (msg, &err, &debug_info); + g_printerr ("Error received from element %s: %s\n", GST_OBJECT_NAME (msg->src), err->message); + g_printerr ("Debugging information: %s\n", debug_info ? debug_info : "none"); + g_clear_error (&err); + g_free (debug_info); + + g_main_loop_quit (data->main_loop); +} + +/* This function is called when playbin2 has created the appsrc element, so we have + * a chance to configure it. */ +static void source_setup (GstElement *pipeline, GstElement *source, CustomData *data) { + gchar *audio_caps_text; + GstCaps *audio_caps; + + g_print ("Source has been created. Configuring.\n"); + data->app_source = source; + + /* Configure appsrc */ + audio_caps_text = g_strdup_printf (AUDIO_CAPS, SAMPLE_RATE); + audio_caps = gst_caps_from_string (audio_caps_text); + g_object_set (source, "caps", audio_caps, NULL); + g_signal_connect (source, "need-data", G_CALLBACK (start_feed), data); + g_signal_connect (source, "enough-data", G_CALLBACK (stop_feed), data); + gst_caps_unref (audio_caps); + g_free (audio_caps_text); +} + +int main(int argc, char *argv[]) { + CustomData data; + GstBus *bus; + guint flags; + + /* Initialize cumstom data structure */ + memset (&data, 0, sizeof (data)); + data.b = 1; /* For waveform generation */ + data.d = 1; + + /* Initialize GStreamer */ + gst_init (&argc, &argv); + + /* Create the playbin2 element */ + data.pipeline = gst_parse_launch ("playbin2 uri=appsrc://", NULL); + g_signal_connect (data.pipeline, "source-setup", G_CALLBACK (source_setup), &data); + + /* Instruct the bus to emit signals for each received message, and connect to the interesting signals */ + bus = gst_element_get_bus (data.pipeline); + gst_bus_add_signal_watch (bus); + g_signal_connect (G_OBJECT (bus), "message::error", (GCallback)error_cb, &data); + gst_object_unref (bus); + + /* Start playing the pipeline */ + gst_element_set_state (data.pipeline, GST_STATE_PLAYING); + + /* Create a GLib Main Loop and set it to run */ + data.main_loop = g_main_loop_new (NULL, FALSE); + g_main_loop_run (data.main_loop); + + /* Free resources */ + gst_element_set_state (data.pipeline, GST_STATE_NULL); + gst_object_unref (data.pipeline); + return 0; +} diff --git a/gst-sdk/tutorials/vs2010/playback-tutorial-3/playback-tutorial-3.vcxproj b/gst-sdk/tutorials/vs2010/playback-tutorial-3/playback-tutorial-3.vcxproj new file mode 100644 index 0000000..41f16d0 --- /dev/null +++ b/gst-sdk/tutorials/vs2010/playback-tutorial-3/playback-tutorial-3.vcxproj @@ -0,0 +1,95 @@ + + + + + Debug + Win32 + + + Debug + x64 + + + Release + Win32 + + + Release + x64 + + + + + + + Win32Proj + {B84F4F87-E804-456C-874E-AC76E0116268} + v4.0 + + + + Application + true + Unicode + + + Application + false + true + Unicode + + + + + + + + + + + + + + + + + true + + + false + + + + + + Level3 + Disabled + WIN32;_DEBUG;_CONSOLE;%(PreprocessorDefinitions) + + + Console + true + %(AdditionalDependencies) + %(AdditionalLibraryDirectories) + + + + + Level3 + + + MaxSpeed + true + true + WIN32;NDEBUG;_CONSOLE;%(PreprocessorDefinitions) + + + Console + false + true + + + + + + \ No newline at end of file diff --git a/gst-sdk/tutorials/vs2010/playback-tutorial-3/playback-tutorial-3.vcxproj.filters b/gst-sdk/tutorials/vs2010/playback-tutorial-3/playback-tutorial-3.vcxproj.filters new file mode 100644 index 0000000..97cf279 --- /dev/null +++ b/gst-sdk/tutorials/vs2010/playback-tutorial-3/playback-tutorial-3.vcxproj.filters @@ -0,0 +1,6 @@ + + + + + + \ No newline at end of file diff --git a/gst-sdk/tutorials/vs2010/tutorials.sln b/gst-sdk/tutorials/vs2010/tutorials.sln index 39690ca..224fb25 100644 --- a/gst-sdk/tutorials/vs2010/tutorials.sln +++ b/gst-sdk/tutorials/vs2010/tutorials.sln @@ -27,6 +27,8 @@ Project("{8BC9CEB8-8B4A-11D0-8D11-00A0C91BC942}") = "basic-tutorial-12", "basic- EndProject Project("{8BC9CEB8-8B4A-11D0-8D11-00A0C91BC942}") = "playback-tutorial-4", "playback-tutorial-4\playback-tutorial-4.vcxproj", "{0342A79A-3522-416B-A4F8-58F5664B8415}" EndProject +Project("{8BC9CEB8-8B4A-11D0-8D11-00A0C91BC942}") = "playback-tutorial-3", "playback-tutorial-3\playback-tutorial-3.vcxproj", "{B84F4F87-E804-456C-874E-AC76E0116268}" +EndProject Global GlobalSection(SolutionConfigurationPlatforms) = preSolution Debug|Win32 = Debug|Win32 @@ -139,6 +141,14 @@ Global {0342A79A-3522-416B-A4F8-58F5664B8415}.Release|Win32.Build.0 = Release|Win32 {0342A79A-3522-416B-A4F8-58F5664B8415}.Release|x64.ActiveCfg = Release|x64 {0342A79A-3522-416B-A4F8-58F5664B8415}.Release|x64.Build.0 = Release|x64 + {B84F4F87-E804-456C-874E-AC76E0116268}.Debug|Win32.ActiveCfg = Debug|Win32 + {B84F4F87-E804-456C-874E-AC76E0116268}.Debug|Win32.Build.0 = Debug|Win32 + {B84F4F87-E804-456C-874E-AC76E0116268}.Debug|x64.ActiveCfg = Debug|x64 + {B84F4F87-E804-456C-874E-AC76E0116268}.Debug|x64.Build.0 = Debug|x64 + {B84F4F87-E804-456C-874E-AC76E0116268}.Release|Win32.ActiveCfg = Release|Win32 + {B84F4F87-E804-456C-874E-AC76E0116268}.Release|Win32.Build.0 = Release|Win32 + {B84F4F87-E804-456C-874E-AC76E0116268}.Release|x64.ActiveCfg = Release|x64 + {B84F4F87-E804-456C-874E-AC76E0116268}.Release|x64.Build.0 = Release|x64 EndGlobalSection GlobalSection(SolutionProperties) = preSolution HideSolutionNode = FALSE -- 2.7.4