mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-04-26 06:54:49 +00:00
Code Issues 1 Projects Releases Wiki Activity

avtpsrc: Retry receive with same buffer size

Browse source 
Without this patch in case of a retry recv() will be called with a
negative size argument.

Signed-off-by: Timo Wischer <timo.wischer@de.bosch.com>
Part-of: <https://gitlab.freedesktop.org/gstreamer/gstreamer/-/merge_requests/1078>
This commit is contained in:
Timo Wischer 2021-10-06 16:00:56 +02:00 committed by GStreamer Marge Bot
parent 1d833eba60
commit 20b87e39e9
1 changed files with 3 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
subprojects/gst-plugins-bad/ext/avtp/gstavtpsrc.c
View file

@ -272,6 +272,7 @@ gst_avtp_src_fill (GstPushSrc * pushsrc, GstBuffer * buffer)
GstMapInfo map; GstMapInfo map;
gsize buffer_size; gsize buffer_size;
ssize_t n = MAX_AVTPDU_SIZE; ssize_t n = MAX_AVTPDU_SIZE;
ssize_t received = -1;
GstAvtpSrc *avtpsrc = GST_AVTP_SRC (pushsrc); GstAvtpSrc *avtpsrc = GST_AVTP_SRC (pushsrc);
buffer_size = gst_buffer_get_size (buffer); buffer_size = gst_buffer_get_size (buffer);
@ -290,8 +291,8 @@ gst_avtp_src_fill (GstPushSrc * pushsrc, GstBuffer * buffer)
retry: retry:
errno = 0; errno = 0;
n = recv (avtpsrc->sk_fd, map.data, n, 0); received = recv (avtpsrc->sk_fd, map.data, n, 0);
if (n < 0) { if (received < 0) {
if (errno == EINTR) { if (errno == EINTR) {
goto retry; goto retry;
} }