tests/examples/shapewipe/shapewipe-example.c

   1 /* GStreamer
   2  * Copyright (C) 2009 Sebastian Dröge <sebastian.droege@collabora.co.uk>
   3  *
   4  * This library is free software; you can redistribute it and/or
   5  * modify it under the terms of the GNU Library General Public
   6  * License as published by the Free Software Foundation; either
   7  * version 2 of the License, or (at your option) any later version.
   8  *
   9  * This library is distributed in the hope that it will be useful,
  10  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  11  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  12  * Library General Public License for more details.
  13  *
  14  * You should have received a copy of the GNU Library General Public
  15  * License along with this library; if not, write to the
  16  * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
  17  * Boston, MA 02111-1307, USA.
  18  */
  19
  20 #include <gst/gst.h>
  21 #include <gst/controller/gstlfocontrolsource.h>
  22
  23 #include <stdlib.h>
  24
  25 static gboolean
  26 on_message (GstBus * bus, GstMessage * message, gpointer user_data)
  27 {
  28   GMainLoop *loop = (GMainLoop *) user_data;
  29
  30   switch (GST_MESSAGE_TYPE (message)) {
  31     case GST_MESSAGE_ERROR:{
  32       GError *err = NULL;
  33       gchar *debug = NULL;
  34
  35       g_warning ("Got ERROR");
  36       gst_message_parse_error (message, &err, &debug);
  37       g_warning ("%s: %s", err->message, debug);
  38       g_main_loop_quit (loop);
  39       break;
  40     }
  41     case GST_MESSAGE_WARNING:{
  42       GError *err = NULL;
  43       gchar *debug = NULL;
  44
  45       g_warning ("Got WARNING");
  46       gst_message_parse_error (message, &err, &debug);
  47       g_warning ("%s: %s", err->message, debug);
  48       g_main_loop_quit (loop);
  49       break;
  50     }
  51     case GST_MESSAGE_EOS:
  52       g_main_loop_quit (loop);
  53       break;
  54     default:
  55       break;
  56   }
  57
  58   return TRUE;
  59 }
  60
  61 gint
  62 main (gint argc, gchar ** argv)
  63 {
  64   GstElement *pipeline;
  65   GstElement *shapewipe;
  66   GstLFOControlSource *csource;
  67   GValue val = { 0, };
  68   GMainLoop *loop;
  69   GstBus *bus;
  70   gchar *pipeline_string;
  71   gfloat border = 0.05;
  72
  73   if (argc < 2) {
  74     g_print ("Usage: shapewipe mask.png <border>\n");
  75     return -1;
  76   }
  77
  78   gst_init (&argc, &argv);
  79
  80   if (argc > 2) {
  81     border = atof (argv[2]);
  82   }
  83
  84   pipeline_string =
  85       g_strdup_printf
  86       ("videotestsrc ! video/x-raw-yuv,format=(fourcc)AYUV,width=640,height=480 ! shapewipe name=shape border=%f ! videomixer name=mixer ! ffmpegcolorspace ! autovideosink     filesrc location=%s ! typefind ! decodebin2 ! ffmpegcolorspace ! videoscale ! queue ! shape.mask_sink    videotestsrc pattern=snow ! video/x-raw-yuv,format=(fourcc)AYUV,width=640,height=480 ! queue ! mixer.",
  87       border, argv[1]);
  88
  89   pipeline = gst_parse_launch (pipeline_string, NULL);
  90   g_free (pipeline_string);
  91
  92   if (pipeline == NULL) {
  93     g_print ("Failed to create pipeline\n");
  94     return -2;
  95   }
  96
  97   shapewipe = gst_bin_get_by_name (GST_BIN (pipeline), "shape");
  98
  99   csource = gst_lfo_control_source_new ();
 100
 101   gst_object_add_control_binding (GST_OBJECT_CAST (shapewipe),
 102       gst_control_binding_new (GST_OBJECT_CAST (shapewipe), "position",
 103           GST_CONTROL_SOURCE (csource)));
 104
 105   g_value_init (&val, G_TYPE_FLOAT);
 106   g_value_set_float (&val, 0.5);
 107   g_object_set (G_OBJECT (csource), "amplitude", &val, NULL);
 108   g_value_set_float (&val, 0.5);
 109   g_object_set (G_OBJECT (csource), "offset", &val, NULL);
 110   g_value_unset (&val);
 111
 112   g_object_set (G_OBJECT (csource), "frequency", 0.25, NULL);
 113   g_object_set (G_OBJECT (csource), "timeshift", 500 * GST_MSECOND, NULL);
 114
 115   g_object_unref (csource);
 116
 117   loop = g_main_loop_new (NULL, FALSE);
 118
 119   bus = gst_pipeline_get_bus (GST_PIPELINE (pipeline));
 120   gst_bus_add_signal_watch (bus);
 121   g_signal_connect (G_OBJECT (bus), "message", G_CALLBACK (on_message), loop);
 122   gst_object_unref (GST_OBJECT (bus));
 123
 124   if (gst_element_set_state (pipeline,
 125           GST_STATE_PLAYING) == GST_STATE_CHANGE_FAILURE) {
 126     g_error ("Failed to go into PLAYING state");
 127     return -4;
 128   }
 129
 130   g_main_loop_run (loop);
 131
 132   gst_element_set_state (pipeline, GST_STATE_NULL);
 133
 134   g_main_loop_unref (loop);
 135
 136   gst_object_unref (G_OBJECT (pipeline));
 137
 138   return 0;
 139 }