mirrors/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire.git synced 2025-11-27 07:00:12 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

pinossrc: handle format change messages

Browse source
This commit is contained in:
Wim Taymans 2016-04-07 11:39:33 +02:00
parent ccb93c9652
commit 4121c421aa
1 changed files with 23 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

25
pinos/gst/gstpinossrc.c
View file

@ -370,7 +370,7 @@ on_new_buffer (GObject *gobject,
PinosPacketHeader hdr; PinosPacketHeader hdr;
if (!pinos_buffer_iter_parse_header (&it, &hdr)) if (!pinos_buffer_iter_parse_header (&it, &hdr))
goto no_fds; goto parse_failed;
if (GST_CLOCK_TIME_IS_VALID (hdr.pts)) { if (GST_CLOCK_TIME_IS_VALID (hdr.pts)) {
if (hdr.pts > GST_ELEMENT_CAST (pinossrc)->base_time) if (hdr.pts > GST_ELEMENT_CAST (pinossrc)->base_time)
@ -389,7 +389,7 @@ on_new_buffer (GObject *gobject,
int fd; int fd;
if (!pinos_buffer_iter_parse_fd_payload (&it, &data.p)) if (!pinos_buffer_iter_parse_fd_payload (&it, &data.p))
goto no_fds; goto parse_failed;
GST_DEBUG ("got fd payload id %d", data.p.id); GST_DEBUG ("got fd payload id %d", data.p.id);
fd = pinos_buffer_get_fd (pbuf, data.p.fd_index, &error); fd = pinos_buffer_get_fd (pbuf, data.p.fd_index, &error);
if (fd == -1) if (fd == -1)
@ -407,6 +407,20 @@ on_new_buffer (GObject *gobject,
fdpayload_data_destroy); fdpayload_data_destroy);
break; break;
} }
case PINOS_PACKET_TYPE_FORMAT_CHANGE:
{
PinosPacketFormatChange change;
GstCaps *caps;
if (!pinos_buffer_iter_parse_format_change (&it, &change))
goto parse_failed;
GST_DEBUG ("got format change %d %s", change.id, change.format);
caps = gst_caps_from_string (change.format);
gst_base_src_set_caps (GST_BASE_SRC (pinossrc), caps);
gst_caps_unref (caps);
break;
}
default: default:
break; break;
} }
@ -420,6 +434,13 @@ on_new_buffer (GObject *gobject,
return; return;
/* ERRORS */ /* ERRORS */
parse_failed:
{
gst_buffer_unref (buf);
GST_ELEMENT_ERROR (pinossrc, RESOURCE, FAILED, ("buffer parse failure"), (NULL));
pinos_main_loop_signal (pinossrc->loop, FALSE);
return;
}
no_fds: no_fds:
{ {
gst_buffer_unref (buf); gst_buffer_unref (buf);