35bb946
From 56fe0eb7f350b8c75fd952ce930a9ef0f00d45fc Mon Sep 17 00:00:00 2001
35bb946
From: =?UTF-8?q?Zbigniew=20J=C4=99drzejewski-Szmek?= <zbyszek@in.waw.pl>
35bb946
Date: Fri, 20 Oct 2017 12:41:04 +0200
35bb946
Subject: [PATCH] core/dynamic-user: use _cleanup_ in dynamic user locking
35bb946
35bb946
This makes the code a bit easier to read.
35bb946
35bb946
(cherry picked from commit 362d90b7f2776f7fabf78274587fd38ceb1b1c12)
35bb946
---
35bb946
 src/core/dynamic-user.c | 78 +++++++++++++++++++++++++++----------------------
35bb946
 1 file changed, 43 insertions(+), 35 deletions(-)
35bb946
35bb946
diff --git a/src/core/dynamic-user.c b/src/core/dynamic-user.c
35bb946
index 8f229d27ff..0f4ec15721 100644
35bb946
--- a/src/core/dynamic-user.c
35bb946
+++ b/src/core/dynamic-user.c
35bb946
@@ -421,9 +421,25 @@ static void unlink_uid_lock(int lock_fd, uid_t uid, const char *name) {
35bb946
         (void) make_uid_symlinks(uid, name, false); /* remove direct lookup symlinks */
35bb946
 }
35bb946
 
35bb946
+static int lockfp(int fd, int *fd_lock) {
35bb946
+        if (lockf(fd, F_LOCK, 0) < 0)
35bb946
+                return -errno;
35bb946
+        *fd_lock = fd;
35bb946
+        return 0;
35bb946
+}
35bb946
+
35bb946
+static void unlockfp(int *fd_lock) {
35bb946
+        if (*fd_lock < 0)
35bb946
+                return;
35bb946
+        lockf(*fd_lock, F_ULOCK, 0);
35bb946
+        *fd_lock = -1;
35bb946
+}
35bb946
+
35bb946
 static int dynamic_user_realize(DynamicUser *d, char **suggested_dirs, uid_t *ret, bool is_user) {
35bb946
 
35bb946
-        _cleanup_close_ int etc_passwd_lock_fd = -1, uid_lock_fd = -1;
35bb946
+        _cleanup_(unlockfp) int storage_socket0_lock = -1;
35bb946
+        _cleanup_close_ int uid_lock_fd = -1;
35bb946
+        _cleanup_close_ int etc_passwd_lock_fd = -1;
35bb946
         uid_t uid = UID_INVALID;
35bb946
         int r;
35bb946
 
35bb946
@@ -432,8 +448,9 @@ static int dynamic_user_realize(DynamicUser *d, char **suggested_dirs, uid_t *re
35bb946
         /* Acquire a UID for the user name. This will allocate a UID for the user name if the user doesn't exist
35bb946
          * yet. If it already exists its existing UID/GID will be reused. */
35bb946
 
35bb946
-        if (lockf(d->storage_socket[0], F_LOCK, 0) < 0)
35bb946
-                return -errno;
35bb946
+        r = lockfp(d->storage_socket[0], &storage_socket0_lock);
35bb946
+        if (r < 0)
35bb946
+                return r;
35bb946
 
35bb946
         r = dynamic_user_pop(d, &uid, &uid_lock_fd);
35bb946
         if (r < 0) {
35bb946
@@ -441,11 +458,11 @@ static int dynamic_user_realize(DynamicUser *d, char **suggested_dirs, uid_t *re
35bb946
                 uid_t new_uid;
35bb946
 
35bb946
                 if (r != -EAGAIN)
35bb946
-                        goto finish;
35bb946
+                        return r;
35bb946
 
35bb946
                 /* OK, nothing stored yet, let's try to find something useful. While we are working on this release the
35bb946
                  * lock however, so that nobody else blocks on our NSS lookups. */
35bb946
-                (void) lockf(d->storage_socket[0], F_ULOCK, 0);
35bb946
+                unlockfp(&storage_socket0_lock);
35bb946
 
35bb946
                 /* Let's see if a proper, static user or group by this name exists. Try to take the lock on
35bb946
                  * /etc/passwd, if that fails with EROFS then /etc is read-only. In that case it's fine if we don't
35bb946
@@ -494,9 +511,10 @@ static int dynamic_user_realize(DynamicUser *d, char **suggested_dirs, uid_t *re
35bb946
                 }
35bb946
 
35bb946
                 /* So, we found a working UID/lock combination. Let's see if we actually still need it. */
35bb946
-                if (lockf(d->storage_socket[0], F_LOCK, 0) < 0) {
35bb946
+                r = lockfp(d->storage_socket[0], &storage_socket0_lock);
35bb946
+                if (r < 0) {
35bb946
                         unlink_uid_lock(uid_lock_fd, uid, d->name);
35bb946
-                        return -errno;
35bb946
+                        return r;
35bb946
                 }
35bb946
 
35bb946
                 r = dynamic_user_pop(d, &new_uid, &new_uid_lock_fd);
35bb946
@@ -504,7 +522,7 @@ static int dynamic_user_realize(DynamicUser *d, char **suggested_dirs, uid_t *re
35bb946
                         if (r != -EAGAIN) {
35bb946
                                 /* OK, something bad happened, let's get rid of the bits we acquired. */
35bb946
                                 unlink_uid_lock(uid_lock_fd, uid, d->name);
35bb946
-                                goto finish;
35bb946
+                                return r;
35bb946
                         }
35bb946
 
35bb946
                         /* Great! Nothing is stored here, still. Store our newly acquired data. */
35bb946
@@ -525,17 +543,14 @@ static int dynamic_user_realize(DynamicUser *d, char **suggested_dirs, uid_t *re
35bb946
          * dynamically right here, push that in along with the lock fd for it. */
35bb946
         r = dynamic_user_push(d, uid, uid_lock_fd);
35bb946
         if (r < 0)
35bb946
-                goto finish;
35bb946
+                return r;
35bb946
 
35bb946
         *ret = uid;
35bb946
-        r = 0;
35bb946
-
35bb946
-finish:
35bb946
-        (void) lockf(d->storage_socket[0], F_ULOCK, 0);
35bb946
-        return r;
35bb946
+        return 0;
35bb946
 }
35bb946
 
35bb946
 static int dynamic_user_current(DynamicUser *d, uid_t *ret) {
35bb946
+        _cleanup_(unlockfp) int storage_socket0_lock = -1;
35bb946
         _cleanup_close_ int lock_fd = -1;
35bb946
         uid_t uid;
35bb946
         int r;
35bb946
@@ -545,23 +560,20 @@ static int dynamic_user_current(DynamicUser *d, uid_t *ret) {
35bb946
 
35bb946
         /* Get the currently assigned UID for the user, if there's any. This simply pops the data from the storage socket, and pushes it back in right-away. */
35bb946
 
35bb946
-        if (lockf(d->storage_socket[0], F_LOCK, 0) < 0)
35bb946
-                return -errno;
35bb946
+        r = lockfp(d->storage_socket[0], &storage_socket0_lock);
35bb946
+        if (r < 0)
35bb946
+                return r;
35bb946
 
35bb946
         r = dynamic_user_pop(d, &uid, &lock_fd);
35bb946
         if (r < 0)
35bb946
-                goto finish;
35bb946
+                return r;
35bb946
 
35bb946
         r = dynamic_user_push(d, uid, lock_fd);
35bb946
         if (r < 0)
35bb946
-                goto finish;
35bb946
+                return r;
35bb946
 
35bb946
         *ret = uid;
35bb946
-        r = 0;
35bb946
-
35bb946
-finish:
35bb946
-        (void) lockf(d->storage_socket[0], F_ULOCK, 0);
35bb946
-        return r;
35bb946
+        return 0;
35bb946
 }
35bb946
 
35bb946
 static DynamicUser* dynamic_user_ref(DynamicUser *d) {
35bb946
@@ -589,6 +601,7 @@ static DynamicUser* dynamic_user_unref(DynamicUser *d) {
35bb946
 }
35bb946
 
35bb946
 static int dynamic_user_close(DynamicUser *d) {
35bb946
+        _cleanup_(unlockfp) int storage_socket0_lock = -1;
35bb946
         _cleanup_close_ int lock_fd = -1;
35bb946
         uid_t uid;
35bb946
         int r;
35bb946
@@ -596,25 +609,20 @@ static int dynamic_user_close(DynamicUser *d) {
35bb946
         /* Release the user ID, by releasing the lock on it, and emptying the storage socket. After this the user is
35bb946
          * unrealized again, much like it was after it the DynamicUser object was first allocated. */
35bb946
 
35bb946
-        if (lockf(d->storage_socket[0], F_LOCK, 0) < 0)
35bb946
-                return -errno;
35bb946
+        r = lockfp(d->storage_socket[0], &storage_socket0_lock);
35bb946
+        if (r < 0)
35bb946
+                return r;
35bb946
 
35bb946
         r = dynamic_user_pop(d, &uid, &lock_fd);
35bb946
-        if (r == -EAGAIN) {
35bb946
+        if (r == -EAGAIN)
35bb946
                 /* User wasn't realized yet, nothing to do. */
35bb946
-                r = 0;
35bb946
-                goto finish;
35bb946
-        }
35bb946
+                return 0;
35bb946
         if (r < 0)
35bb946
-                goto finish;
35bb946
+                return r;
35bb946
 
35bb946
         /* This dynamic user was realized and dynamically allocated. In this case, let's remove the lock file. */
35bb946
         unlink_uid_lock(lock_fd, uid, d->name);
35bb946
-        r = 1;
35bb946
-
35bb946
-finish:
35bb946
-        (void) lockf(d->storage_socket[0], F_ULOCK, 0);
35bb946
-        return r;
35bb946
+        return 1;
35bb946
 }
35bb946
 
35bb946
 static DynamicUser* dynamic_user_destroy(DynamicUser *d) {