diff -r 567bb019e3e3 -r 7e817e7e631c gstreamer_core/tsrc/examples/gstseek/src/gstseek.c --- a/gstreamer_core/tsrc/examples/gstseek/src/gstseek.c Tue Aug 31 15:30:33 2010 +0300 +++ /dev/null Thu Jan 01 00:00:00 1970 +0000 @@ -1,234 +0,0 @@ - -#include -#include -#include -#include - -#define LOG_FILE "c:\\logs\\launch_logs.txt" -#include "std_log_result.h" -#define LOG_FILENAME_LINE __FILE__, __LINE__ - - -void create_xml(int result) -{ - - if(result) - { - assert_failed = 1; - } - - testResultXml(xmlfile); - close_log_file(); - - if(result) - { - exit (-1); - } - -} - -GstElement *pipeline, *source, *wavparse,*sink,*conv,*resample,*decoder,*audioconvert,*audioresample ; -GstBus *bus; -GMainLoop *loop; - -static gboolean -bus_call (GstBus *bus, - GstMessage *msg, - gpointer data) -{ - switch (GST_MESSAGE_TYPE (msg)) { - case GST_MESSAGE_EOS: - gst_element_set_state (pipeline, GST_STATE_NULL); - g_main_loop_quit(loop); - gst_object_unref (GST_OBJECT (pipeline)); - std_log(LOG_FILENAME_LINE, "Test Successful"); - create_xml(0); - break; - case GST_MESSAGE_ERROR: { - gchar *debug; - GError *err; - gst_message_parse_error (msg, &err, &debug); - g_free (debug); - g_print ("Error: %s\n", err->message); - g_error_free (err); - std_log(LOG_FILENAME_LINE, "Test Failed"); - create_xml(1); - break; - } - default: - break; - } - - return TRUE; -} - -static gboolean cb_autoplug( GstBin * *bin, - GstPad *pad, - GstCaps *caps, - gpointer user_data) -{ - GstCaps* sinkcaps = NULL; - gboolean supported = FALSE; - - GstPad* sinkpad = gst_element_get_pad( sink, "sink"); - sinkcaps = gst_pad_get_caps( sinkpad ); - supported = gst_caps_is_subset( caps, sinkcaps ); - - if( supported ) - { - //link_with_devsoundsink = TRUE; - return FALSE; - } - return TRUE; -} - -static void -cb_newpad (GstElement *decodebin, - GstPad *pad, - gboolean last, - gpointer data) -{ - GstCaps *caps; - GstStructure *str; - GstPadLinkReturn linkret= GST_PAD_LINK_OK ; - - - GstPad* sinkpad = NULL; - - - /* check media type */ - caps = gst_pad_get_caps (pad); - str = gst_caps_get_structure (caps, 0); - if (!g_strrstr (gst_structure_get_name (str), "audio")) { - gst_caps_unref (caps); - return; - } - gst_caps_unref (caps); - -// if( link_with_devsoundsink ) -// { - sinkpad = gst_element_get_pad( sink, "sink"); - //gst_bin_add_many (GST_BIN (pipeline),source, decoder,sink, NULL); - -// } -// else -// { -// audioconvert = gst_element_factory_make ("audioconvert", "audioconvert"); -// audioresample = gst_element_factory_make ("audioresample", "audioresample"); -// sinkpad = gst_element_get_pad( audioconvert, "sink"); -// -// gst_bin_add_many (GST_BIN (pipeline),source, decoder,audioconvert,audioresample,sink, NULL); -// -// if (!gst_element_link (audioconvert,audioresample)) -// g_error ("link(audioconvert,audioresample, sink) failed!\n"); -// if (!gst_element_link (audioresample, sink)) -// g_error ("link(audioconvert,audioresample, sink) failed!\n"); -// } - - linkret = gst_pad_link (pad, sinkpad); -} - - -static gboolean -cb_get_position (GstElement* temp /*pipeline*/) -{ - GstFormat fmt = GST_FORMAT_TIME; - gint64 pos = 0, len, time_nanoseconds, diff; - GstState state; - - gst_element_get_state(GST_ELEMENT(pipeline),&state,NULL,-1); - if (gst_element_query_position (pipeline, &fmt, &pos) - && gst_element_query_duration (pipeline, &fmt, &len)) { - g_print ("Time: %" GST_TIME_FORMAT " / %" GST_TIME_FORMAT "\r", - GST_TIME_ARGS (pos), GST_TIME_ARGS (len)); - } - time_nanoseconds = pos + 1000000000; - - if (!gst_element_seek (pipeline, 1.0, GST_FORMAT_TIME, GST_SEEK_FLAG_FLUSH, - GST_SEEK_TYPE_SET, time_nanoseconds, - GST_SEEK_TYPE_NONE, GST_CLOCK_TIME_NONE)) { - g_print ("Seek failed!\n"); - } - - gst_element_get_state(GST_ELEMENT(pipeline),&state,NULL,-1); - - if (gst_element_query_position (pipeline, &fmt, &pos) - && gst_element_query_duration (pipeline, &fmt, &len)) { - g_print ("Time: %" GST_TIME_FORMAT " / %" GST_TIME_FORMAT "\r", - GST_TIME_ARGS (pos), GST_TIME_ARGS (len)); - } - - diff = pos - time_nanoseconds; - - if( diff > 1000000 ) - { - create_xml( 1 ); - } - - /* call me again */ - return TRUE; -} - -int main (int argc, char *argv[]) -{ - - xmlfile = "launch_logs"; - std_log(LOG_FILENAME_LINE, "Test Started launch"); - - if (argc != 2) { - g_print ("usage: %s \n", argv[0]); - std_log(LOG_FILENAME_LINE, "Test Failed"); - create_xml(1); - exit (-1); - } - //link_with_devsoundsink = FALSE; - gst_init (&argc, &argv); - loop = g_main_loop_new (NULL, FALSE); - - /* create elements */ - pipeline = gst_pipeline_new ("audio-player"); - source = gst_element_factory_make ("filesrc", "file-source"); - decoder = gst_element_factory_make ("decodebin2", "decodebin2-decoder"); - sink = gst_element_factory_make ("devsoundsink", "sink"); -// audioconvert = gst_element_factory_make ("audioconvert", "audioconvert"); -// audioresample = gst_element_factory_make ("audioresample", "audioresample"); -// sink = gst_element_factory_make ("devsoundsink", "sink"); - - if (!pipeline || !source || !decoder || !sink) { - g_print ("One element could not be created\n"); - return -1; - } - /* set filename property on the file source. Also add a message handler. */ - g_object_set (G_OBJECT (source), "location", argv[1], NULL); - /* put all elements in a bin */ - gst_bin_add_many (GST_BIN (pipeline),source, decoder,sink, NULL); - /* link together - note that we cannot link the parser and decoder yet, because the parser uses dynamic pads. For that, we set a pad-added signal handler. */ - gst_element_link (source, decoder); - - - - - gst_bus_add_watch (gst_pipeline_get_bus (GST_PIPELINE (pipeline)), bus_call, loop); - - g_signal_connect (decoder, "new-decoded-pad", G_CALLBACK (cb_newpad), NULL); - g_signal_connect (decoder, "autoplug-continue", G_CALLBACK (cb_autoplug), NULL); - - g_timeout_add (1000/*in mili sec*/, (GSourceFunc) cb_get_position, NULL); - - //g_signal_connect (decoder, "pad-added", G_CALLBACK (new_pad_cb),pipeline); - /* Now set to playing and iterate. */ - g_print ("Setting to PLAYING\n"); - gst_element_set_state (pipeline, GST_STATE_PLAYING); - g_print ("Running\n"); - g_main_loop_run (loop); - /* clean up nicely */ - g_print ("Returned, stopping playback\n"); - gst_element_set_state (pipeline, GST_STATE_NULL); - g_print ("Deleting pipeline\n"); - gst_object_unref (GST_OBJECT (pipeline)); - - g_print ("completed palying audio\n"); - //std_log(LOG_FILENAME_LINE, "Test Successful"); - //create_xml(0); - return 0; -}