sd-varlink: check correct errno

'n' can also be assigned from recvmsg_safe(), which is our own
func returning negative errno.

diff --git a/src/libsystemd/sd-varlink/sd-varlink.c b/src/libsystemd/sd-varlink/sd-varlink.c
index 447d5c333c040884675aa7772ea296c40c6d5a1f..4665913b1c44238a54232d136ae87dd0bf8771b6 100644 (file)
--- a/src/libsystemd/sd-varlink/sd-varlink.c
+++ b/src/libsystemd/sd-varlink/sd-varlink.c
@@ -870,23 +870,25 @@ static int varlink_read(sd_varlink *v) {
                 bool prefer_read = v->prefer_read;
                 if (!prefer_read) {
                         n = recv(v->input_fd, p, rs, MSG_DONTWAIT);
-                        if (n < 0 && errno == ENOTSOCK)
+                        if (n < 0)
+                                n = -errno;
+                        if (n == -ENOTSOCK)
                                 prefer_read = v->prefer_read = true;
                 }
-                if (prefer_read)
+                if (prefer_read) {
                         n = read(v->input_fd, p, rs);
-        }
-        if (n < 0) {
-                if (errno == EAGAIN)
-                        return 0;
-
-                if (ERRNO_IS_DISCONNECT(errno)) {
-                        v->read_disconnected = true;
-                        return 1;
+                        if (n < 0)
+                                n = -errno;
                 }
-
-                return -errno;
         }
+        if (ERRNO_IS_NEG_TRANSIENT(n))
+                return 0;
+        if (ERRNO_IS_NEG_DISCONNECT(n)) {
+                v->read_disconnected = true;
+                return 1;
+        }
+        if (n < 0)
+                return n;
         if (n == 0) { /* EOF */
 
                 if (v->allow_fd_passing_input)
@@ -897,7 +899,7 @@ static int varlink_read(sd_varlink *v) {
         }
 
         if (v->allow_fd_passing_input) {
-                struct cmsghdr* cmsg;
+                struct cmsghdr *cmsg;
 
                 cmsg = cmsg_find(&mh, SOL_SOCKET, SCM_RIGHTS, (socklen_t) -1);
                 if (cmsg) {