rtspconnection: Handle EOF on writev() after checking for all other error conditions
authorSebastian Dröge <sebastian@centricular.com>
Fri, 30 Nov 2018 10:47:57 +0000 (12:47 +0200)
committerSebastian Dröge <sebastian@centricular.com>
Tue, 29 Jan 2019 12:17:23 +0000 (14:17 +0200)
Otherwise we would return EOF if nothing was written in any case, even
if this was actually a case of TIMEOUT or EWOULDBLOCK for example.

Thanks to Edward Hervey for debugging and finding this issue.

gst-libs/gst/rtsp/gstrtspconnection.c

index abc933f5986ba05316fb20b5b416c2f2fc6167cf..ae393e4149784de7d42a54099d65b0a1b3663e55 100644 (file)
@@ -1269,7 +1269,7 @@ writev_bytes (GOutputStream * stream, GOutputVector * vectors, gint n_vectors,
           g_pollable_output_stream_writev_nonblocking (G_POLLABLE_OUTPUT_STREAM
           (stream), vectors, n_vectors, &written, cancellable, &err);
     _bytes_written += written;
-    if (G_UNLIKELY (!res))
+    if (G_UNLIKELY (!res || written == 0))
       goto error;
 
     /* skip vectors that have been written in full */
@@ -1295,10 +1295,8 @@ error:
   {
     *bytes_written = _bytes_written;
 
-    if (G_UNLIKELY (written == 0))
-      return GST_RTSP_EEOF;
-
-    GST_DEBUG ("%s", err->message);
+    if (err)
+      GST_DEBUG ("%s", err->message);
     if (g_error_matches (err, G_IO_ERROR, G_IO_ERROR_CANCELLED)) {
       g_clear_error (&err);
       return GST_RTSP_EINTR;
@@ -1308,7 +1306,11 @@ error:
     } else if (g_error_matches (err, G_IO_ERROR, G_IO_ERROR_TIMED_OUT)) {
       g_clear_error (&err);
       return GST_RTSP_ETIMEOUT;
+    } else if (G_UNLIKELY (written == 0)) {
+      g_clear_error (&err);
+      return GST_RTSP_EEOF;
     }
+
     g_clear_error (&err);
     return GST_RTSP_ESYS;
   }