mirrors/pulseaudio
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pulseaudio/pulseaudio.git synced 2025-11-01 22:58:47 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

rtp: Use udpsink instead of fdsink for the GStreamer RTP implementation

Browse source
This commit is contained in:
Sebastian Dröge 2016-03-14 17:38:59 +02:00 • committed by Arun Raghavan
parent 7f6571e1cc
commit 72dbbcbc65
1 changed files with 27 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

29
src/modules/rtp/rtp-gstreamer.c
View file

@ -68,12 +68,17 @@ static GstCaps* caps_from_sample_spec(const pa_sample_spec *ss) {
static bool init_send_pipeline(pa_rtp_context *c, int fd, uint8_t payload, size_t mtu, const pa_sample_spec *ss) {
GstElement *appsrc = NULL, *pay = NULL, *capsf = NULL, *rtpbin = NULL, *sink = NULL;
GstCaps *caps;
GSocket *socket;
GInetSocketAddress *addr;
GInetAddress *iaddr;
guint16 port;
gchar *addr_str;
MAKE_ELEMENT(appsrc, "appsrc");
MAKE_ELEMENT(pay, "rtpL16pay");
MAKE_ELEMENT(capsf, "capsfilter");
MAKE_ELEMENT(rtpbin, "rtpbin");
MAKE_ELEMENT(sink, "fdsink");
MAKE_ELEMENT(sink, "udpsink");
c->pipeline = gst_pipeline_new(NULL);
@ -85,9 +90,29 @@ static bool init_send_pipeline(pa_rtp_context *c, int fd, uint8_t payload, size_
goto fail;
}
socket = g_socket_new_from_fd(fd, NULL);
if (!socket) {
pa_log("Failed to create socket");
goto fail;
}
addr = G_INET_SOCKET_ADDRESS(g_socket_get_remote_address(socket, NULL));
iaddr = g_inet_socket_address_get_address(addr);
addr_str = g_inet_address_to_string(iaddr);
port = g_inet_socket_address_get_port(addr);
g_object_set(appsrc, "caps", caps, "is-live", TRUE, "blocksize", mtu, "format", 3 /* time */, NULL);
g_object_set(pay, "mtu", mtu, NULL);
g_object_set(sink, "fd", fd, "enable-last-sample", FALSE, NULL);
g_object_set(sink, "socket", socket, "host", addr_str, "port", port,
"enable-last-sample", FALSE, "sync", FALSE, "loop",
g_socket_get_multicast_loopback(socket), "ttl",
g_socket_get_ttl(socket), "ttl-mc",
g_socket_get_multicast_ttl(socket), "auto-multicast", FALSE,
NULL);
g_free(addr_str);
g_object_unref(addr);
g_object_unref(socket);
gst_caps_unref(caps);