/* GStreamer

 * Copyright (C) 2005 Andy Wingo <wingo@pobox.com>

 *

 * simple_launch_lines.c: Unit test for simple pipelines

 *

 * This library is free software; you can redistribute it and/or

 * modify it under the terms of the GNU Library General Public

 * License as published by the Free Software Foundation; either

 * version 2 of the License, or (at your option) any later version.

 *

 * This library is distributed in the hope that it will be useful,

 * but WITHOUT ANY WARRANTY; without even the implied warranty of

 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU

 * Library General Public License for more details.

 *

 * You should have received a copy of the GNU Library General Public

 * License along with this library; if not, write to the

 * Free Software Foundation, Inc., 59 Temple Place - Suite 330,

 * Boston, MA 02111-1307, USA.

 */

#define LOG_FILE "c:\\logs\\simple-launch-lines_log1.txt"

#include <gst/gst_global.h>

#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();

}

#include "libgstreamer_wsd_solution.h" 

#if EMULATOR

GET_GLOBAL_VAR_FROM_TLS(buffers,gstcheck,GList*)

#define buffers (*GET_GSTREAMER_WSD_VAR_NAME(buffers,gstcheck,g)())

#else 

extern GList *buffers = NULL;

#endif

#if EMULATOR

static GET_GLOBAL_VAR_FROM_TLS(raised_critical,gstcheck,gboolean)

#define _gst_check_raised_critical (*GET_GSTREAMER_WSD_VAR_NAME(raised_critical,gstcheck,g)())

#else 

#endif

//gboolean _gst_check_raised_warning = FALSE;

#if EMULATOR

static GET_GLOBAL_VAR_FROM_TLS(raised_warning,gstcheck,gboolean)

#define _gst_check_raised_warning (*GET_GSTREAMER_WSD_VAR_NAME(raised_warning,gstcheck,g)())

#else 

#endif

//gboolean _gst_check_expecting_log = FALSE;

#if EMULATOR

static GET_GLOBAL_VAR_FROM_TLS(expecting_log,gstcheck,gboolean)

#define _gst_check_expecting_log (*GET_GSTREAMER_WSD_VAR_NAME(expecting_log,gstcheck,g)())

#else 

#endif

#include <gst/check/gstcheck.h>

static GstElement *

setup_pipeline (gchar * pipe_descr)

{

  GstElement *pipeline;

  pipeline = gst_parse_launch (pipe_descr, NULL);

  fail_unless (GST_IS_PIPELINE (pipeline));

  return pipeline;

}

/*

 * run_pipeline:

 * @pipe: the pipeline to run

 * @desc: the description for use in messages

 * @message_types: is a mask of expected message_types

 * @tmessage: is the expected terminal message

 *

 * the poll call will time out after half a second.

 */

static void

run_pipeline (GstElement * pipeline, gchar * descr,

    GstMessageType message_types, GstMessageType tmessage)

{

  GstBus *bus;

  GstMessageType rmessage;

  GstStateChangeReturn ret;

  fail_if (pipeline == NULL);

  bus = gst_element_get_bus (pipeline);

  fail_if (bus == NULL);

  ret = gst_element_set_state (pipeline, GST_STATE_PLAYING);

  ret = gst_element_get_state (pipeline, NULL, NULL, GST_CLOCK_TIME_NONE);

  if (ret != GST_STATE_CHANGE_SUCCESS) {

    g_critical ("Couldn't set pipeline to PLAYING");

    goto done;

  }

  while (1) {

    GstMessage *message = gst_bus_poll (bus, GST_MESSAGE_ANY, GST_SECOND / 2);

    if (message) {

      rmessage = GST_MESSAGE_TYPE (message);

      gst_message_unref (message);

    } else {

      rmessage = GST_MESSAGE_UNKNOWN;

    }

    if (rmessage == tmessage) {

      break;

    } else if (rmessage == GST_MESSAGE_UNKNOWN) {

      g_critical ("Unexpected timeout in gst_bus_poll, looking for %d: %s",

          tmessage, descr);

      break;

    } else if (rmessage & message_types) {

      continue;

    }

    g_critical

        ("Unexpected message received of type %d, '%s', looking for %d: %s",

        rmessage, gst_message_type_get_name (rmessage), tmessage, descr);

  }

done:

  gst_element_set_state (pipeline, GST_STATE_NULL);

  gst_object_unref (pipeline);

  gst_object_unref (bus);

}

{

  gchar *s;

  GstElement *fakesrc, *fakesink, *pipeline;

  xmlfile = "test_2_elements";

  std_log(LOG_FILENAME_LINE, "Test Started test_2_elements");

  //change for parse

  s = "fakesrc can-activate-push=false ! fakesink can-activate-pull=true";

  pipeline = gst_pipeline_new ("audio-player");

  fakesrc = gst_element_factory_make ("fakesrc", NULL);  

  fakesink = gst_element_factory_make ("fakesink", NULL);  

  gst_bin_add_many (GST_BIN (pipeline), fakesrc, fakesink, NULL);

  gst_element_link_many (fakesrc, fakesink, NULL);  

  g_object_set (G_OBJECT (fakesrc), "can-activate-push", FALSE, NULL);

  g_object_set (G_OBJECT (fakesink), "can-activate-pull", TRUE, NULL);

  run_pipeline (pipeline, s,

      GST_MESSAGE_NEW_CLOCK | GST_MESSAGE_STATE_CHANGED |

      GST_MESSAGE_ASYNC_DONE, GST_MESSAGE_UNKNOWN);

  //change for parse

  s = "fakesrc can-activate-push=true ! fakesink can-activate-pull=false";

  pipeline = gst_pipeline_new ("audio-player");

    fakesrc = gst_element_factory_make ("fakesrc", NULL);  

    fakesink = gst_element_factory_make ("fakesink", NULL);  

    gst_bin_add_many (GST_BIN (pipeline), fakesrc, fakesink, NULL);

    gst_element_link_many (fakesrc, fakesink, NULL);  

    g_object_set (G_OBJECT (fakesrc), "can-activate-push", TRUE, NULL);

    g_object_set (G_OBJECT (fakesink), "can-activate-pull", FALSE, NULL);

  run_pipeline (pipeline, s,

      GST_MESSAGE_NEW_CLOCK | GST_MESSAGE_STATE_CHANGED |

      GST_MESSAGE_ASYNC_DONE, GST_MESSAGE_UNKNOWN);

  //change for parse

  s = "fakesrc can-activate-push=false num-buffers=10 ! fakesink can-activate-pull=true";

  pipeline = gst_pipeline_new ("audio-player");

  fakesrc = gst_element_factory_make ("fakesrc", NULL);  

  fakesink = gst_element_factory_make ("fakesink", NULL);  

  gst_bin_add_many (GST_BIN (pipeline), fakesrc, fakesink, NULL);

  gst_element_link_many (fakesrc, fakesink, NULL);  

  g_object_set (G_OBJECT (fakesrc), "can-activate-push", FALSE, NULL);

  g_object_set (G_OBJECT (fakesrc), "num-buffers", 10, NULL);

  g_object_set (G_OBJECT (fakesink), "can-activate-pull", TRUE, NULL);

  run_pipeline (pipeline, s,

      GST_MESSAGE_NEW_CLOCK | GST_MESSAGE_STATE_CHANGED |

      GST_MESSAGE_ASYNC_DONE, GST_MESSAGE_EOS);

  //change for parse

  s = "fakesrc can-activate-push=true num-buffers=10 ! fakesink can-activate-pull=false";

  pipeline = gst_pipeline_new ("audio-player");

    fakesrc = gst_element_factory_make ("fakesrc", NULL);  

    fakesink = gst_element_factory_make ("fakesink", NULL);  

    gst_bin_add_many (GST_BIN (pipeline), fakesrc, fakesink, NULL);

    gst_element_link_many (fakesrc, fakesink, NULL);  

    g_object_set (G_OBJECT (fakesrc), "can-activate-push", TRUE, NULL);

    g_object_set (G_OBJECT (fakesrc), "num-buffers", 10, NULL);

    g_object_set (G_OBJECT (fakesink), "can-activate-pull", FALSE, NULL);

  run_pipeline (pipeline, s,

      GST_MESSAGE_NEW_CLOCK | GST_MESSAGE_STATE_CHANGED |

      GST_MESSAGE_ASYNC_DONE, GST_MESSAGE_EOS);

  //change for parse

  s = "fakesrc can-activate-push=false ! fakesink can-activate-pull=false";

  pipeline = gst_pipeline_new ("audio-player");

  fakesrc = gst_element_factory_make ("fakesrc", NULL);  

  fakesink = gst_element_factory_make ("fakesink", NULL);  

  gst_bin_add_many (GST_BIN (pipeline), fakesrc, fakesink, NULL);

  gst_element_link_many (fakesrc, fakesink, NULL);  

  g_object_set (G_OBJECT (fakesrc), "can-activate-push", FALSE, NULL);

  g_object_set (G_OBJECT (fakesink), "can-activate-pull", FALSE, NULL);

  ASSERT_CRITICAL (run_pipeline (pipeline, s,

          GST_MESSAGE_NEW_CLOCK | GST_MESSAGE_STATE_CHANGED |

          GST_MESSAGE_ASYNC_DONE, GST_MESSAGE_UNKNOWN));

            std_log(LOG_FILENAME_LINE, "Test Successful");

					  create_xml(0);  

}

static void

check_state_change_return (GstElement * pipeline, GstState state,

    GstStateChangeReturn immediate, GstStateChangeReturn final)

{

  GstStateChangeReturn ret;

  ret = gst_element_set_state (pipeline, state);

  if (ret != immediate)

    g_critical ("Unexpected set_state return ->%s: %d != %d",

        gst_element_state_get_name (state), ret, immediate);

            TEST_ASSERT_FAIL

  ret = gst_element_get_state (pipeline, NULL, NULL, GST_CLOCK_TIME_NONE);

  if (ret != final)

    g_critical ("Unexpected get_state return ->%s: %d != %d",

        gst_element_state_get_name (state), ret, final);

        TEST_ASSERT_FAIL

}

void test_state_change_returns()

{

  gchar *s;

   GstElement *fakesrc, *fakesink, *pipeline;

  xmlfile = "test_state_change_returns";

  std_log(LOG_FILENAME_LINE, "Test Started test_state_change_returns");

  //change for parse

  s = "fakesrc can-activate-pull=false ! fakesink";

  pipeline = gst_pipeline_new ("audio-player");

    fakesrc = gst_element_factory_make ("fakesrc", NULL);  

    fakesink = gst_element_factory_make ("fakesink", NULL);  

    gst_bin_add_many (GST_BIN (pipeline), fakesrc, fakesink, NULL);

    gst_element_link_many (fakesrc, fakesink, NULL);  

    g_object_set (G_OBJECT (fakesrc), "can-activate-pull", FALSE, NULL);

  //pipeline = gst_parse_launch (s, NULL);

  fail_unless (GST_IS_PIPELINE (pipeline));

  check_state_change_return (pipeline, GST_STATE_READY,

      GST_STATE_CHANGE_SUCCESS, GST_STATE_CHANGE_SUCCESS);

  check_state_change_return (pipeline, GST_STATE_PAUSED, GST_STATE_CHANGE_ASYNC,

      GST_STATE_CHANGE_SUCCESS);

  check_state_change_return (pipeline, GST_STATE_PLAYING,

      GST_STATE_CHANGE_SUCCESS, GST_STATE_CHANGE_SUCCESS);

  /* can't check PAUSED, it's not deterministic */

  check_state_change_return (pipeline, GST_STATE_READY,

      GST_STATE_CHANGE_SUCCESS, GST_STATE_CHANGE_SUCCESS);

  check_state_change_return (pipeline, GST_STATE_NULL, GST_STATE_CHANGE_SUCCESS,

      GST_STATE_CHANGE_SUCCESS);

  gst_object_unref (pipeline);

  //change for parse

  s = "fakesrc can-activate-push=false ! fakesink can-activate-pull=true";

  pipeline = gst_pipeline_new ("audio-player");

  fakesrc = gst_element_factory_make ("fakesrc", NULL);  

  fakesink = gst_element_factory_make ("fakesink", NULL);  

  gst_bin_add_many (GST_BIN (pipeline), fakesrc, fakesink, NULL);

  gst_element_link_many (fakesrc, fakesink, NULL);  

  g_object_set (G_OBJECT (fakesrc), "can-activate-push", FALSE, NULL);

  g_object_set (G_OBJECT (fakesink), "can-activate-pull", TRUE, NULL);

  //pipeline = gst_parse_launch (s, NULL);

  fail_unless (GST_IS_PIPELINE (pipeline));

  std_log(LOG_FILENAME_LINE, "Test Successful");

  create_xml(0);

}

//G_GNUC_UNUSED

void test_tee()

{

  gchar *s;

  GstElement *fakesrc, *fakesink, *pipeline, *tee, *queue, *fakesink1;

  GstPad *pad,*pad1;

  gboolean bl;

  xmlfile = "test_tee";

  std_log(LOG_FILENAME_LINE, "Test Started test_tee");

  //for parse change

  s = "fakesrc can-activate-push=true ! tee ! fakesink can-activate-push=true";

  pipeline = gst_pipeline_new ("audio-player");

   fakesrc = gst_element_factory_make ("fakesrc", NULL);

   tee = gst_element_factory_make ("tee", NULL);  

   fakesink = gst_element_factory_make ("fakesink", NULL);  

  // g_object_set (G_OBJECT (fakesrc), "num-buffers", 20, NULL);

   gst_bin_add_many (GST_BIN (pipeline), fakesrc, tee,  fakesink, NULL);

   bl = gst_element_link_many(fakesrc, tee, fakesink, NULL);

   g_object_set (G_OBJECT (fakesrc), "can-activate-push", TRUE, NULL);

   g_object_set (G_OBJECT (fakesink), "can-activate-push", TRUE, NULL);

  run_pipeline (pipeline, s,

      GST_MESSAGE_NEW_CLOCK | GST_MESSAGE_STATE_CHANGED, GST_MESSAGE_UNKNOWN);

  //for parse change

  s = "fakesrc can-activate-push=true num-buffers=10 ! tee ! fakesink can-activate-push=true";

  pipeline = gst_pipeline_new ("audio-player");

 fakesrc = gst_element_factory_make ("fakesrc", NULL);

 tee = gst_element_factory_make ("tee", NULL);  

 fakesink = gst_element_factory_make ("fakesink", NULL);  

 gst_bin_add_many (GST_BIN (pipeline), fakesrc, tee, fakesink, NULL);

 gst_element_link_many (fakesrc, tee, fakesink, NULL);  

 g_object_set (G_OBJECT (fakesrc), "can-activate-push", TRUE, NULL);

 g_object_set (G_OBJECT (fakesrc), "num-buffers", 10, NULL);

 g_object_set (G_OBJECT (fakesink), "can-activate-push", TRUE, NULL);

  run_pipeline (pipeline, s,

      GST_MESSAGE_NEW_CLOCK | GST_MESSAGE_STATE_CHANGED, GST_MESSAGE_EOS);

  //for parse change

  s = "fakesrc can-activate-push=false can-activate-pull=true ! tee ! fakesink can-activate-pull=true";

  pipeline = gst_pipeline_new ("audio-player");

   fakesrc = gst_element_factory_make ("fakesrc", NULL);

   tee = gst_element_factory_make ("tee", NULL);  

   fakesink = gst_element_factory_make ("fakesink", NULL);  

   gst_bin_add_many (GST_BIN (pipeline), fakesrc, tee, fakesink, NULL);

   gst_element_link_many (fakesrc, tee, fakesink, NULL);  

   g_object_set (G_OBJECT (fakesrc), "can-activate-push", FALSE, NULL);

   g_object_set (G_OBJECT (fakesrc), "can-activate-pull", TRUE, NULL);

   g_object_set (G_OBJECT (fakesink), "can-activate-pull", TRUE, NULL);

  ASSERT_CRITICAL (run_pipeline (pipeline, s,

          GST_MESSAGE_NEW_CLOCK | GST_MESSAGE_STATE_CHANGED,

          GST_MESSAGE_UNKNOWN));

  //for parse change

  s = "fakesrc can-activate-push=false can-activate-pull=true "

      "! tee pull-mode=single ! fakesink can-activate-pull=true";

  pipeline = gst_pipeline_new ("audio-player");

 fakesrc = gst_element_factory_make ("fakesrc", NULL);

 tee = gst_element_factory_make ("tee", NULL);  

 fakesink = gst_element_factory_make ("fakesink", NULL);  

 gst_bin_add_many (GST_BIN (pipeline), fakesrc, tee, fakesink, NULL);

 gst_element_link_many (fakesrc, tee, fakesink, NULL);  

 g_object_set (G_OBJECT (fakesrc), "can-activate-push", FALSE, NULL);

 g_object_set (G_OBJECT (fakesrc), "can-activate-pull", TRUE, NULL);

 g_object_set (G_OBJECT (tee), "pull-mode", "single", NULL);

 g_object_set (G_OBJECT (fakesink), "can-activate-pull", TRUE, NULL);

  run_pipeline (pipeline, s,

      GST_MESSAGE_NEW_CLOCK | GST_MESSAGE_STATE_CHANGED, GST_MESSAGE_UNKNOWN);

  //for parse change

  s = "fakesrc can-activate-push=false can-activate-pull=true num-buffers=10 "

      "! tee pull-mode=single ! fakesink can-activate-pull=true";

  pipeline = gst_pipeline_new ("audio-player");

  fakesrc = gst_element_factory_make ("fakesrc", NULL);

  tee = gst_element_factory_make ("tee", NULL);  

  fakesink = gst_element_factory_make ("fakesink", NULL);  

  gst_bin_add_many (GST_BIN (pipeline), fakesrc, tee, fakesink, NULL);

  gst_element_link_many (fakesrc, tee, fakesink, NULL);  

  g_object_set (G_OBJECT (fakesrc), "can-activate-push", FALSE, NULL);

  g_object_set (G_OBJECT (fakesrc), "can-activate-pull", TRUE, NULL);

  g_object_set (G_OBJECT (fakesrc), "num-buffers", 10, NULL);

  g_object_set (G_OBJECT (tee), "pull-mode", "single", NULL);

  g_object_set (G_OBJECT (fakesink), "can-activate-pull", TRUE, NULL);

  run_pipeline (pipeline, s,

      GST_MESSAGE_NEW_CLOCK | GST_MESSAGE_STATE_CHANGED, GST_MESSAGE_EOS);

  //for parse change

  s = "fakesrc can-activate-push=false can-activate-pull=true "

      "! tee name=t pull-mode=single ! fakesink can-activate-pull=true "

      "t. ! queue ! fakesink can-activate-pull=true can-activate-push=false";

  pipeline = gst_pipeline_new ("audio-player");

    fakesrc = gst_element_factory_make ("fakesrc", NULL);

    tee = gst_element_factory_make ("tee", "t");  

    fakesink = gst_element_factory_make ("fakesink", NULL);

    queue = gst_element_factory_make ("queue", NULL);

    fakesink1 = gst_element_factory_make ("fakesink", NULL);

    gst_bin_add_many (GST_BIN (pipeline), fakesrc, tee, fakesink, queue, fakesink1, NULL);

    g_object_set (G_OBJECT (fakesrc), "can-activate-push", FALSE, NULL);

    g_object_set (G_OBJECT (fakesrc), "can-activate-pull", TRUE, NULL);

    g_object_set (G_OBJECT (tee), "pull-mode", "single", NULL);

    g_object_set (G_OBJECT (fakesink), "can-activate-pull", TRUE, NULL);

    g_object_set (G_OBJECT (fakesink1), "can-activate-pull", TRUE, NULL);

    g_object_set (G_OBJECT (fakesink1), "can-activate-push", FALSE, NULL);

    gst_element_link_many (fakesrc, tee, fakesink, NULL); 

    gst_element_link_many (tee, queue, fakesink1, NULL); 

  ASSERT_CRITICAL (run_pipeline (pipeline, s,

          GST_MESSAGE_NEW_CLOCK | GST_MESSAGE_STATE_CHANGED,

          GST_MESSAGE_UNKNOWN));

  s = "fakesrc can-activate-push=false can-activate-pull=true "

      "! tee name=t pull-mode=single ! fakesink can-activate-pull=true "

      "t. ! queue ! fakesink";

  pipeline = gst_pipeline_new ("audio-player");

  fakesrc = gst_element_factory_make ("fakesrc", NULL);

  tee = gst_element_factory_make ("tee", "t");  

  fakesink = gst_element_factory_make ("fakesink", NULL);

  queue = gst_element_factory_make ("queue", NULL);

  fakesink1 = gst_element_factory_make ("fakesink", NULL);

  gst_bin_add_many (GST_BIN (pipeline), fakesrc, tee, fakesink, queue, fakesink1, NULL);

  g_object_set (G_OBJECT (fakesrc), "can-activate-push", FALSE, NULL);

  g_object_set (G_OBJECT (fakesrc), "can-activate-pull", TRUE, NULL);

  g_object_set (G_OBJECT (tee), "pull-mode", "single", NULL);

  g_object_set (G_OBJECT (fakesink), "can-activate-pull", TRUE, NULL);

  gst_element_link_many (fakesrc, tee, fakesink, NULL); 

  gst_element_link_many (tee, queue, fakesink1, NULL); 

  run_pipeline (pipeline, s,

      GST_MESSAGE_NEW_CLOCK | GST_MESSAGE_STATE_CHANGED, GST_MESSAGE_UNKNOWN);

  s = "fakesrc can-activate-push=false can-activate-pull=true num-buffers=10 "

      "! tee name=t pull-mode=single ! fakesink can-activate-pull=true "

      "t. ! queue ! fakesink";

  pipeline = gst_pipeline_new ("audio-player");

   fakesrc = gst_element_factory_make ("fakesrc", NULL);

   tee = gst_element_factory_make ("tee", "t");  

   fakesink = gst_element_factory_make ("fakesink", NULL);

   queue = gst_element_factory_make ("queue", NULL);

   fakesink1 = gst_element_factory_make ("fakesink", NULL);

   gst_bin_add_many (GST_BIN (pipeline), fakesrc, tee, fakesink, queue, fakesink1, NULL);

   g_object_set (G_OBJECT (fakesrc), "can-activate-push", FALSE, NULL);

   g_object_set (G_OBJECT (fakesrc), "can-activate-pull", TRUE, NULL);

   g_object_set (G_OBJECT (fakesrc), "num-buffers", 10, NULL);