RESPONDERS: refactor create_pipe_fd()

Resolves:
https://fedorahosted.org/sssd/ticket/2470

Reviewed-by: Jakub Hrozek <jhrozek@redhat.com>

2 files changed, 13 insertions, 10 deletions

diff --git a/src/responder/common/responder.h b/src/responder/common/responder.h
index 8837e1142..cd2b3232c 100644
--- a/src/responder/common/responder.h
+++ b/src/responder/common/responder.h
@@ -178,7 +178,7 @@ responder_get_domain(struct resp_ctx *rctx, const char *domain);
 errno_t responder_get_domain_by_id(struct resp_ctx *rctx, const char *id,
                                    struct sss_domain_info **_ret_dom);
 
-int create_pipe_fd(const char *sock_name, int *fd, mode_t umaskval);
+int create_pipe_fd(const char *sock_name, int *_fd, mode_t umaskval);
 
 /* responder_cmd.c */
 int sss_cmd_empty_packet(struct sss_packet *packet);
diff --git a/src/responder/common/responder_common.c b/src/responder/common/responder_common.c
index 85aa04335..9a13c95d6 100644
--- a/src/responder/common/responder_common.c
+++ b/src/responder/common/responder_common.c
@@ -584,24 +584,25 @@ static int sss_dp_init(struct resp_ctx *rctx,
     return EOK;
 }
 
-int create_pipe_fd(const char *sock_name, int *fd, mode_t umaskval)
+int create_pipe_fd(const char *sock_name, int *_fd, mode_t umaskval)
 {
     struct sockaddr_un addr;
     errno_t ret;
+    int fd;
 
-    *fd = socket(AF_UNIX, SOCK_STREAM, 0);
-    if (*fd == -1) {
+    fd = socket(AF_UNIX, SOCK_STREAM, 0);
+    if (fd == -1) {
         return EIO;
     }
 
     umask(umaskval);
 
-    ret = set_nonblocking(*fd);
+    ret = set_nonblocking(fd);
     if (ret != EOK) {
         goto done;
     }
 
-    ret = set_close_on_exec(*fd);
+    ret = set_close_on_exec(fd);
     if (ret != EOK) {
         goto done;
     }
@@ -619,13 +620,13 @@ int create_pipe_fd(const char *sock_name, int *fd, mode_t umaskval)
               "Cannot remove old socket (errno=%d), bind might fail!\n", ret);
     }
 
-    if (bind(*fd, (struct sockaddr *)&addr, sizeof(addr)) == -1) {
+    if (bind(fd, (struct sockaddr *)&addr, sizeof(addr)) == -1) {
         DEBUG(SSSDBG_FATAL_FAILURE,
               "Unable to bind on socket '%s'\n", sock_name);
         ret = EIO;
         goto done;
     }
-    if (listen(*fd, 10) != 0) {
+    if (listen(fd, 10) == -1) {
         DEBUG(SSSDBG_FATAL_FAILURE,
               "Unable to listen on socket '%s'\n", sock_name);
         ret = EIO;
@@ -638,8 +639,10 @@ done:
     /* we want default permissions on created files to be very strict,
        so set our umask to 0177 */
     umask(0177);
-    if (ret != EOK) {
-        close(*fd);
+    if (ret == EOK) {
+        *_fd = fd;
+    } else {
+        close(fd);
     }
     return ret;
 }