1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
|
/*
* sydra
*
* sydra is a toolbox which allows you to set up multiple bidirectional
* Video/Audio streams from external locations.
* sydra has been written to be used for the Elevate Festival in Graz
* Austria in order to involve external locations to present themselves
* at the festival.
* Sydra is based on GStreamer and is written in C.
*
*
* Copyright (C) 2014 Christian Pointner <equinox@spreadspace.org>
*
* This file is part of sydra.
*
* sydra is free software: you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation, either version 3 of the License, or
* any later version.
*
* sydra 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 General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with sydra. If not, see <http://www.gnu.org/licenses/>.
*
* In addition, as a special exception, the copyright holders hereby
* grant permission for non-GPL-compatible GStreamer plugins to be used
* and distributed together with GStreamer and sydra.
* This permission goes above and beyond the permissions granted by the
* GPL license sydra is covered by.
*/
#include "utils.h"
#include "log.h"
#include <gst/gst.h>
GstElement* sydra_create_bin_from_desc(const char* type, const char* desc)
{
GError *error = NULL;
GstElement *bin = gst_parse_bin_from_description(desc, TRUE, &error);
if(!bin) {
log_printf(ERROR, "Bin description for %s parser error: %s", type, error ? error->message : "unknown");
g_error_free(error);
return NULL;
}
if(error) {
log_printf(WARNING, "Bin description for %s parser warning: %s", type, error ? error->message : "unknown");
g_error_free(error);
}
return bin;
}
GstElement* sydra_create_element(const char* type, const char* name)
{
GstElement *e = gst_element_factory_make (type, name);
if(!e) {
log_printf(ERROR, "Error creating element %s%sof type %s", name ? name : "", name ? " " : "", type);
return NULL;
}
return e;
}
static gboolean sydra_link_pads(GstElement* src, GstPad* src_pad, const char* src_pad_name, GstElement* sink, GstPad* sink_pad, const char* sink_pad_name)
{
if(!src_pad || !sink_pad)
return FALSE;
GstPadLinkReturn ret = gst_pad_link(src_pad, sink_pad);
gst_object_unref(GST_OBJECT(src_pad));
gst_object_unref(GST_OBJECT(sink_pad));
if(GST_PAD_LINK_FAILED(ret)) {
gchar* src_name = gst_element_get_name(src);
gchar* sink_name = gst_element_get_name(sink);
log_printf(ERROR, "Error linking pad '%s' of '%s' with pad '%s' of '%s'",
src_pad_name, src_name, sink_pad_name, sink_name);
g_free(src_name);
g_free(sink_name);
return FALSE;
}
return TRUE;
}
gboolean sydra_link_request_static(GstElement* src, const char* src_pad_name, GstElement* sink, const char* sink_pad_name)
{
GstPad *src_pad = gst_element_get_request_pad(src, src_pad_name);
GstPad *sink_pad = gst_element_get_static_pad(sink, sink_pad_name);
return sydra_link_pads(src, src_pad, src_pad_name, sink, sink_pad, sink_pad_name);
}
gboolean sydra_link_static_request(GstElement* src, const char* src_pad_name, GstElement* sink, const char* sink_pad_name)
{
GstPad *src_pad = gst_element_get_static_pad(src, src_pad_name);
GstPad *sink_pad = gst_element_get_request_pad(sink, sink_pad_name);
return sydra_link_pads(src, src_pad, src_pad_name, sink, sink_pad, sink_pad_name);
}
gboolean sydra_link_static_static(GstElement* src, const char* src_pad_name, GstElement* sink, const char* sink_pad_name)
{
GstPad *src_pad = gst_element_get_static_pad(src, src_pad_name);
GstPad *sink_pad = gst_element_get_static_pad(sink, sink_pad_name);
return sydra_link_pads(src, src_pad, src_pad_name, sink, sink_pad, sink_pad_name);
}
gboolean sydra_link_static_compatible(GstElement* src, const char* src_pad_name, GstElement* sink)
{
GstPad *src_pad = gst_element_get_static_pad(src, src_pad_name);
if(!src_pad) return FALSE;
GstPad *sink_pad = gst_element_get_compatible_pad(sink, src_pad, NULL);
if(!sink_pad) return FALSE;
gchar* sink_pad_name = gst_pad_get_name(sink_pad);
gboolean res = sydra_link_pads(src, src_pad, src_pad_name, sink, sink_pad, sink_pad_name);
g_free(sink_pad_name);
return res;
}
|
