2 This file is part of GNUnet.
3 Copyright (C) 2016 GNUnet e.V.
5 GNUnet is free software: you can redistribute it and/or modify it
6 under the terms of the GNU Affero General Public License as published
7 by the Free Software Foundation, either version 3 of the License,
8 or (at your option) any later version.
10 GNUnet is distributed in the hope that it will be useful, but
11 WITHOUT ANY WARRANTY; without even the implied warranty of
12 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13 Affero General Public License for more details.
15 You should have received a copy of the GNU Affero General Public License
16 along with this program. If not, see <http://www.gnu.org/licenses/>.
18 SPDX-License-Identifier: AGPL3.0-or-later
21 * @file conversation/gnunet_gst_test.c
26 #include "gnunet_gst_def.h"
27 #include "gnunet_gst.h"
30 main (int argc, char *argv[])
32 struct GNUNET_gstData *gst;
34 GstElement *gnunetsrc, *gnunetsink, *source, *sink, *encoder, *decoder;
37 // audio_message = GNUNET_malloc (UINT16_MAX);
38 // audio_message->header.type = htons (GNUNET_MESSAGE_TYPE_CONVERSATION_AUDIO);
41 // GstPipeline *pipeline;
43 gst = (GNUNET_gstData *) malloc (sizeof(struct GNUNET_gstData));
45 // gst->audio_message.header.type = htons (GNUNET_MESSAGE_TYPE_CONVERSATION_AUDIO);
48 gg_load_configuration (gst);
50 gst->audiobackend = JACK;
51 gst->dropsilence = TRUE;
53 *//* Initialize GStreamer */gst_init (&argc, &argv);
55 gst->pipeline = GST_PIPELINE (gst_pipeline_new ("gnunet-media-helper"));
59 printf ("this is the speaker \n");
62 int type = MICROPHONE;
63 printf ("this is the microphone \n");
67 gnunetsrc = GST_ELEMENT (get_app (gst, SOURCE));
69 sink = GST_ELEMENT (get_audiobin (gst, SINK));
70 decoder = GST_ELEMENT (get_coder (gst, DECODER));
71 gst_bin_add_many (GST_BIN (gst->pipeline), gnunetsrc, decoder, sink, NULL);
72 gst_element_link_many (gnunetsrc, decoder, sink, NULL);
74 if (type == MICROPHONE)
76 source = GST_ELEMENT (get_audiobin (gst, SOURCE));
78 encoder = GST_ELEMENT (get_coder (gst, ENCODER));
80 gnunetsink = GST_ELEMENT (get_app (gst, SINK));
82 gst_bin_add_many (GST_BIN (gst->pipeline), source, encoder, gnunetsink,
84 gst_element_link_many (source, encoder, gnunetsink, NULL);
87 gst_bin_add_many( GST_BIN(gst->pipeline), appsource, appsink, source, encoder, decoder, sink, NULL);
88 gst_element_link_many( source, encoder, decoder, sink , NULL);
90 pl_graph (gst->pipeline);
92 gst_element_set_state (GST_ELEMENT (gst->pipeline), GST_STATE_PLAYING);
94 // pl_graph(gst->pipeline);
96 /* Wait until error or EOS */
97 // bus = gst_element_get_bus (GST_ELEMENT(gst->pipeline));
98 // bus_watch_id = gst_bus_add_watch (bus, gnunet_gst_bus_call, pipeline);
100 gg_setup_gst_bus (gst);
101 // g_print ("Running...\n");
104 // start pushing buffers
105 if (type == MICROPHONE)
108 loop = g_main_loop_new (NULL, FALSE);
110 g_main_loop_run (loop);
116 flow = on_appsink_new_sample (gst->appsink, gst);
123 // printf("read.. \n");
127 g_print ("Returned, stopping playback\n");
129 // gst_object_unref (bus);
130 gst_element_set_state (GST_ELEMENT (gst->pipeline), GST_STATE_NULL);
131 gst_object_unref (gst->pipeline);