1 /*
2  * GStreamer
3  * Copyright (C) 2017 Vivia Nikolaidou <vivia@toolsonair.com>
4  *
5  * test-audiomixmatrix.c
6  *
7  * This library is free software; you can redistribute it and/or
8  * modify it under the terms of the GNU Library General Public
9  * License as published by the Free Software Foundation; either
10  * version 2 of the License, or (at your option) any later version.
11  *
12  * This library is distributed in the hope that it will be useful,
13  * but WITHOUT ANY WARRANTY; without even the implied warranty of
14  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
15  * Library General Public License for more details.
16  *
17  * You should have received a copy of the GNU Library General Public
18  * License along with this library; if not, write to the
19  * Free Software Foundation, Inc., 51 Franklin St, Fifth Floor,
20  * Boston, MA 02110-1301, USA.
21  */
22 
23 #include <gst/gst.h>
24 #include <string.h>
25 
26 static gboolean
message_cb(GstBus * bus,GstMessage * message,gpointer user_data)27 message_cb (GstBus * bus, GstMessage * message, gpointer user_data)
28 {
29   switch (GST_MESSAGE_TYPE (message)) {
30     case GST_MESSAGE_ERROR:{
31       GError *err = NULL;
32       gchar *debug = NULL;
33 
34       gst_message_parse_error (message, &err, &debug);
35       gst_printerrln ("Error message received: %s", err->message);
36       gst_printerrln ("Debug info: %s", debug);
37       g_error_free (err);
38       g_free (debug);
39     }
40     case GST_MESSAGE_EOS:
41       g_main_loop_quit (user_data);
42       break;
43     default:
44       break;
45   }
46   return TRUE;
47 }
48 
49 static GstPadProbeReturn
_event_received(GstPad * pad,GstPadProbeInfo * info,gpointer user_data)50 _event_received (GstPad * pad, GstPadProbeInfo * info, gpointer user_data)
51 {
52   GstCaps *caps;
53   gchar *caps_str;
54   GstEvent *event = GST_EVENT (info->data);
55 
56   if (GST_EVENT_TYPE (event) != GST_EVENT_CAPS)
57     return GST_PAD_PROBE_OK;
58 
59   gst_event_parse_caps (event, &caps);
60   if (!gst_caps_is_fixed (caps))
61     return GST_PAD_PROBE_OK;
62 
63   caps_str = gst_caps_to_string (caps);
64 
65   g_print ("Caps received on %s: %s\n",
66       GST_PAD_IS_SRC (pad) ? "source" : "sink", caps_str);
67 
68   g_free (caps_str);
69 
70   return GST_PAD_PROBE_OK;
71 }
72 
73 int
main(int argc,char ** argv)74 main (int argc, char **argv)
75 {
76   GstElement *audiotestsrc, *capsfilter, *audiomixmatrix, *audioconvert, *sink;
77   GstPad *srcpad, *sinkpad;
78   GstBus *bus;
79   GMainLoop *loop;
80   GstCaps *caps;
81   GValue v2 = G_VALUE_INIT;
82   GValue v3 = G_VALUE_INIT;
83   GstElement *pipeline;
84   GValue v = G_VALUE_INIT;
85   gchar *serialized_matrix;
86 
87   gst_init (&argc, &argv);
88 
89   audiotestsrc = gst_element_factory_make ("audiotestsrc", "audiotestsrc");
90   capsfilter = gst_element_factory_make ("capsfilter", "capsfilter");
91   caps =
92       gst_caps_from_string
93       ("audio/x-raw,channels=4,channel-mask=(bitmask)0,format=S32LE");
94   g_object_set (capsfilter, "caps", caps, NULL);
95   gst_caps_unref (caps);
96   audiomixmatrix =
97       gst_element_factory_make ("audiomixmatrix", "audiomixmatrix");
98   g_object_set (audiomixmatrix, "in-channels", 4, NULL);
99   g_object_set (audiomixmatrix, "out-channels", 2, NULL);
100   g_object_set (audiomixmatrix, "channel-mask", 3, NULL);
101   /* So the serialized matrix will be: < < 1, 0, 0, 0 >, < 0, 1, 0, 0 > > */
102   g_value_init (&v, GST_TYPE_ARRAY);
103   g_value_init (&v2, GST_TYPE_ARRAY);
104   g_value_init (&v3, G_TYPE_DOUBLE);
105   g_value_set_double (&v3, 1);
106   gst_value_array_append_value (&v2, &v3);
107   g_value_unset (&v3);
108   g_value_init (&v3, G_TYPE_DOUBLE);
109   g_value_set_double (&v3, 0);
110   gst_value_array_append_value (&v2, &v3);
111   g_value_unset (&v3);
112   g_value_init (&v3, G_TYPE_DOUBLE);
113   g_value_set_double (&v3, 0);
114   gst_value_array_append_value (&v2, &v3);
115   g_value_unset (&v3);
116   g_value_init (&v3, G_TYPE_DOUBLE);
117   g_value_set_double (&v3, 0);
118   gst_value_array_append_value (&v2, &v3);
119   g_value_unset (&v3);
120   gst_value_array_append_value (&v, &v2);
121   g_value_unset (&v2);
122   g_value_init (&v2, GST_TYPE_ARRAY);
123   g_value_init (&v3, G_TYPE_DOUBLE);
124   g_value_set_double (&v3, 0);
125   gst_value_array_append_value (&v2, &v3);
126   g_value_unset (&v3);
127   g_value_init (&v3, G_TYPE_DOUBLE);
128   g_value_set_double (&v3, 1);
129   gst_value_array_append_value (&v2, &v3);
130   g_value_unset (&v3);
131   g_value_init (&v3, G_TYPE_DOUBLE);
132   g_value_set_double (&v3, 0);
133   gst_value_array_append_value (&v2, &v3);
134   g_value_unset (&v3);
135   g_value_init (&v3, G_TYPE_DOUBLE);
136   g_value_set_double (&v3, 0);
137   gst_value_array_append_value (&v2, &v3);
138   g_value_unset (&v3);
139   gst_value_array_append_value (&v, &v2);
140   g_value_unset (&v2);
141   g_object_set_property (G_OBJECT (audiomixmatrix), "matrix", &v);
142   /* Alternatively: gst_util_set_object_arg (audiomixmatrix, "matrix", "< < 1, 0> ..."); */
143   serialized_matrix = gst_value_serialize (&v);
144   gst_printerrln ("Serialized matrix: %s", serialized_matrix);
145   g_free (serialized_matrix);
146   g_value_unset (&v);
147   audioconvert = gst_element_factory_make ("audioconvert", "audioconvert");
148   sink = gst_element_factory_make ("autoaudiosink", "sink");
149   pipeline = gst_pipeline_new ("pipe");
150   gst_bin_add_many (GST_BIN (pipeline), audiotestsrc, capsfilter,
151       audiomixmatrix, audioconvert, sink, NULL);
152   gst_element_link_many (audiotestsrc, capsfilter,
153       audiomixmatrix, audioconvert, sink, NULL);
154 
155   srcpad = gst_element_get_static_pad (audiomixmatrix, "src");
156   gst_pad_add_probe (srcpad, GST_PAD_PROBE_TYPE_EVENT_DOWNSTREAM,
157       _event_received, NULL, NULL);
158   gst_object_unref (srcpad);
159   sinkpad = gst_element_get_static_pad (audiomixmatrix, "sink");
160   gst_pad_add_probe (sinkpad, GST_PAD_PROBE_TYPE_EVENT_DOWNSTREAM,
161       _event_received, NULL, NULL);
162   gst_object_unref (sinkpad);
163 
164   if (gst_element_set_state (pipeline, GST_STATE_PLAYING) ==
165       GST_STATE_CHANGE_FAILURE) {
166     g_printerr ("ERROR: Could not change state in pipeline!\n");
167     gst_object_unref (pipeline);
168     return 1;
169   }
170 
171   bus = gst_pipeline_get_bus (GST_PIPELINE (pipeline));
172   loop = g_main_loop_new (NULL, FALSE);
173   gst_bus_add_signal_watch (bus);
174   g_signal_connect (G_OBJECT (bus), "message", G_CALLBACK (message_cb), loop);
175   g_main_loop_run (loop);
176 
177   gst_element_set_state (pipeline, GST_STATE_NULL);
178   gst_object_unref (bus);
179   gst_object_unref (pipeline);
180 
181 
182   return 0;
183 
184 }
185