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/gstcontroller.h>
  22 #include <gst/controller/gstlfocontrolsource.h>
  23
  24 #include <stdlib.h>
  25
  26 static gboolean
  27 on_message (GstBus * bus, GstMessage * message, gpointer user_data)
  28 {
  29   GMainLoop *loop = (GMainLoop *) user_data;
  30
  31   switch (GST_MESSAGE_TYPE (message)) {
  32     case GST_MESSAGE_ERROR:{
  33       GError *err = NULL;
  34       gchar *debug = NULL;
  35
  36       g_warning ("Got ERROR");
  37       gst_message_parse_error (message, &err, &debug);
  38       g_warning ("%s: %s", err->message, debug);
  39       g_main_loop_quit (loop);
  40       break;
  41     }
  42     case GST_MESSAGE_WARNING:{
  43       GError *err = NULL;
  44       gchar *debug = NULL;
  45
  46       g_warning ("Got WARNING");
  47       gst_message_parse_error (message, &err, &debug);
  48       g_warning ("%s: %s", err->message, debug);
  49       g_main_loop_quit (loop);
  50       break;
  51     }
  52     case GST_MESSAGE_EOS:
  53       g_main_loop_quit (loop);
  54       break;
  55     default:
  56       break;
  57   }
  58
  59   return TRUE;
  60 }
  61
  62 gint
  63 main (gint argc, gchar ** argv)
  64 {
  65   GstElement *pipeline;
  66   GstElement *shapewipe;
  67   GstController *ctrl;
  68   GstLFOControlSource *csource;
  69   GValue val = { 0, };
  70   GMainLoop *loop;
  71   GstBus *bus;
  72   gchar *pipeline_string;
  73   gfloat border = 0.05;
  74
  75   if (argc < 2) {
  76     g_print ("Usage: shapewipe mask.png <border>\n");
  77     return -1;
  78   }
  79
  80   gst_init (&argc, &argv);
  81   gst_controller_init (&argc, &argv);
  82
  83   if (argc > 2) {
  84     border = atof (argv[2]);
  85   }
  86
  87   pipeline_string =
  88       g_strdup_printf
  89       ("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.",
  90       border, argv[1]);
  91
  92   pipeline = gst_parse_launch (pipeline_string, NULL);
  93   g_free (pipeline_string);
  94
  95   if (pipeline == NULL) {
  96     g_print ("Failed to create pipeline\n");
  97     return -2;
  98   }
  99
 100   shapewipe = gst_bin_get_by_name (GST_BIN (pipeline), "shape");
 101
 102   if (!(ctrl = gst_controller_new (G_OBJECT (shapewipe), "position", NULL))) {
 103     g_print ("can't control shapewipe element\n");
 104     return -3;
 105   }
 106
 107   csource = gst_lfo_control_source_new ();
 108
 109   gst_controller_set_control_source (ctrl, "position",
 110       GST_CONTROL_SOURCE (csource));
 111
 112   g_value_init (&val, G_TYPE_FLOAT);
 113   g_value_set_float (&val, 0.5);
 114   g_object_set (G_OBJECT (csource), "amplitude", &val, NULL);
 115   g_value_set_float (&val, 0.5);
 116   g_object_set (G_OBJECT (csource), "offset", &val, NULL);
 117   g_value_unset (&val);
 118
 119   g_object_set (G_OBJECT (csource), "frequency", 0.25, NULL);
 120   g_object_set (G_OBJECT (csource), "timeshift", 500 * GST_MSECOND, NULL);
 121
 122   g_object_unref (csource);
 123
 124   loop = g_main_loop_new (NULL, FALSE);
 125
 126   bus = gst_pipeline_get_bus (GST_PIPELINE (pipeline));
 127   gst_bus_add_signal_watch (bus);
 128   g_signal_connect (G_OBJECT (bus), "message", G_CALLBACK (on_message), loop);
 129   gst_object_unref (GST_OBJECT (bus));
 130
 131   if (gst_element_set_state (pipeline,
 132           GST_STATE_PLAYING) == GST_STATE_CHANGE_FAILURE) {
 133     g_error ("Failed to go into PLAYING state");
 134     return -4;
 135   }
 136
 137   g_main_loop_run (loop);
 138
 139   gst_element_set_state (pipeline, GST_STATE_NULL);
 140
 141   g_main_loop_unref (loop);
 142
 143   g_object_unref (G_OBJECT (ctrl));
 144   gst_object_unref (G_OBJECT (pipeline));
 145
 146   return 0;
 147 }