swtpm: Make --daemon not racy

Signed-off-by: Nicolas Williams <nico@cryptonector.com>
This commit is contained in:
Nicolas Williams 2021-10-12 11:58:06 -05:00 committed by Stefan Berger
parent 26cdfc77df
commit 98d1d126cd
6 changed files with 335 additions and 82 deletions

View File

@ -17,7 +17,7 @@ noinst_HEADERS = \
main.h \
mainloop.h \
options.h \
osx.h \
daemonize.h \
pidfile.h \
seccomp_profile.h \
server.h \
@ -95,7 +95,7 @@ swtpm_DEPENDENCIES = $(privlib_LTLIBRARIES)
swtpm_SOURCES = \
main.c \
osx.c \
daemonize.c \
swtpm.c \
swtpm_chardev.c
if WITH_CUSE

307
src/swtpm/daemonize.c Normal file
View File

@ -0,0 +1,307 @@
/*
* daemonize.c -- Utility functions for race-free daemonization
*
* (c) Two Sigma Open Source, LLC 2021.
*
* Author: Nicolas Williams <nico@twosigma.com>
*
* All rights reserved.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions are
* met:
*
* Redistributions of source code must retain the above copyright notice,
* this list of conditions and the following disclaimer.
*
* Redistributions in binary form must reproduce the above copyright
* notice, this list of conditions and the following disclaimer in the
* documentation and/or other materials provided with the distribution.
*
* Neither the names of the IBM Corporation nor the names of its
* contributors may be used to endorse or promote products derived from
* this software without specific prior written permission.
*
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
* "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
* LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
* A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
* HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
* SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
* LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
* DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
* THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
* OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
*/
#include "config.h"
#include "daemonize.h"
#include <sys/types.h>
#include <sys/stat.h>
#include <sys/wait.h>
#include <fcntl.h>
#include <errno.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
/*
* daemon(3) is racy because it fork()s and exits in the parent before the
* child can get ready to provide its services.
*
* Not every daemon can set up services before calling daemon(3), as some
* APIs are not fork-safe and must be called in the child-side of the
* daemon(3)'s fork() calls.
*
* Even if a daemon can set up services before calling daemon(3), it will not
* be able to write the correct PID into a pidfile until after daemon(3)
* returns.
*
* E.g.,
*
* #!/bin/bash
*
* # Start a service:
* some-serviced --daemon --pid=... ...
*
* # Call it:
* call-some-service ping || echo "oops, we won the race but lost the game"
*
* To address this we split daemon(3) into two functions, daemonize_prep() and
* daemonize_finish(). A daemon program should call daemonize_prep() early
* when it knows it will have to daemonize (e.g., because of a --daemon
* command-line option), then it should do all the setup required to start
* providing its services, then it should call daemonize_finish().
*
* These two functions do all that daemon(3) does, but in two phases so that
* the original process that calls daemonize_prep() does not exit until the
* service is ready.
*
* daemonize_prep() calls fork(), setsid(), and then forks again, and returns
* in the grandchild, but exits in the original and middle processes when the
* grandchild calls daemonize_finish().
*
* How to use this:
*
* if (daemonize) {
* pid_t old_pid, new_pid;
*
* old_pid = getpid();
* if (daemonize_prep() == -1)
* err(1, "Failed to daemonize");
*
* // We're now in a grandchild, but the original parent should still be
* // waiting.
* new_pid = getpid();
* assert(old_pid != new_pid);
* }
*
* // setup sockets, listen() on them, etc...
* my_setup_service_and_listen_on_sockets();
*
* // Tell the waiting parent and grandparent that we're ready:
* // (doing this even if daemonize_prep() wasn't called is ok)
* daemonize_finish();
*
* // daemonize_finish() did not fork() again:
* assert(new_pid == getpid());
*
* Note: the processes that exit will use _exit(). The process that
* daemonize_prep() returns to should be able to use exit().
*/
static int devnullfd = -1;
static int pfd = -1;
static int
wait_or_die_like_it(pid_t pid)
{
int status;
while (waitpid(pid, &status, 0) == -1) {
if (errno == EINTR)
continue;
/* XXX Should just use err(3). */
fprintf(stderr, "waitpid() failed: %s\n", strerror(errno));
fflush(stderr);
_exit(1);
}
if (WIFSIGNALED(status)) {
/*
* Child died in a fire; die like it so the parent sees the same exit
* status.
*/
kill(getpid(), WTERMSIG(status));
}
if (!WIFEXITED(status)) {
/* If fire doesn't kill us, _exit(). */
_exit(1);
}
/* Child exited willingly. */
return WEXITSTATUS(status);
}
/*
* Prepare to daemonize. When ready, the caller should call
* daemonize_finish().
*
* This arranges for the parent to exit when and only when the child is ready
* to service clients.
*
* This forks a grandchild and returns in the grandchild
* but exits in the parent and grandparent, but only once the child calls
* daemonize_finish() (or exits/dies, whichever comes first).
*
* Because the parent side of the fork() calls _exit(), the child can exit().
*
* Returns -1 on error (sets errno), 0 on success.
*/
int
daemonize_prep(void)
{
ssize_t bytes;
char buf;
int save_errno = errno;
int pfds[2] = { -1, -1 };
pid_t pid;
/*
* Be idempotent. If called twice because, e.g., --daemon is given twice,
* do nothing the second time.
*/
if (pfd != -1)
return 0;
/* Grand parent process. */
fflush(stdout);
fflush(stderr);
pid = fork();
if (pid == (pid_t)-1) {
fprintf(stderr, "Failed to daemonize: Failed to fork: %s\n",
strerror(errno));
return -1;
}
if (pid != 0) {
/*
* Grand parent process: exit when the grandchild is ready or die in
* the same way.
*/
_exit(wait_or_die_like_it(pid));
}
/* Intermediate process. Detach from tty, fork() again. */
if (setsid() == -1) {
fprintf(stderr, "Failed to daemonize: Failed to detach from tty: %s\n",
strerror(errno));
_exit(1);
}
/* Set things up so the grandchild can finish daemonizing. */
devnullfd = open("/dev/null", O_RDWR);
if (devnullfd == -1) {
fprintf(stderr, "Failed to daemonize: Could not open /dev/null: %s\n",
strerror(errno));
_exit(1);
}
if (pipe(pfds) == -1) {
fprintf(stderr, "Failed to daemonize: Could not make a pipe: %s\n",
strerror(errno));
_exit(1);
}
pfd = pfds[1];
/* Fork the grandchild so it cannot get a controlling tty by accident. */
pid = fork();
if (pid == (pid_t)-1) {
fprintf(stderr, "Failed to daemonize: Could not fork: %s\n",
strerror(errno));
_exit(1);
}
if (pid != 0) {
/*
* Middle process.
*
* Wait for ready notification from the child, then _exit()
* accordingly.
*/
(void) close(pfds[1]);
do {
bytes = read(pfds[0], &buf, sizeof(buf));
} while (bytes == -1 && errno == EINTR);
if (bytes < 0) {
fprintf(stderr, "Failed to daemonize: "
"Error reading from pipe: %s\n", strerror(errno));
/* Let init reap the grandchild. */
_exit(1);
}
if (bytes == 0) {
/* Die like the grandchild. */
_exit(wait_or_die_like_it(pid));
}
/* Ready! */
_exit(0);
}
/*
* We're on the grandchild side now, and we'll return with the expectation
* that the caller will call daemonize_finish(). The parent, which will
* continue executing this function, will _exit() when the child indicates
* that it is ready.
*/
(void) close(pfds[0]);
errno = save_errno;
return 0;
}
/*
* Indicate that the service is now ready.
*
* Will cause the ancestor processes waiting in daemonize_prep() to _exit().
*/
void
daemonize_finish(void)
{
ssize_t bytes;
int save_errno = errno;
/* pfds[1] will be > -1 IFF daemonize_prep() was called */
if (pfd == -1) {
return;
}
if (chdir("/") == -1) {
fprintf(stderr, "Failed to change directory to /: %s\n",
strerror(errno));
fflush(stderr);
exit(1);
}
if (dup2(devnullfd, STDOUT_FILENO) == -1) {
fprintf(stderr, "Failed to redirect output stream to /dev/null: %s\n",
strerror(errno));
fflush(stderr);
exit(1);
}
if (dup2(devnullfd, STDERR_FILENO) == -1) {
fprintf(stderr, "Failed to redirect error stream to /dev/null: %s\n",
strerror(errno));
fflush(stderr);
exit(1);
}
(void) close(devnullfd);
devnullfd = -1;
do {
bytes = write(pfd, "", sizeof(""));
} while (bytes == -1 && errno == EINTR);
if (bytes <= 0) {
/* There's no point writing to stderr now that it goes to /dev/null */
exit(1);
}
(void) close(pfd);
pfd = -1;
errno = save_errno;
}

View File

@ -1,9 +1,9 @@
/*
* osx.h -- OS X specifics
* daemonize.h -- Race-free daemoninization utilities
*
* (c) Copyright IBM Corporation 2018.
* (c) Copyright IBM Corporation 2021.
*
* Author: Stefan Berger <stefanb@us.ibm.com>
* Author: Nicolas Williams <nico@twosigma.com>
*
* All rights reserved.
*
@ -38,6 +38,7 @@
#ifndef SWTPM_OSX
#define SWTPM_OSX
int osx_daemon(int nochdir, int noclose);
int daemonize_prep(void);
void daemonize_finish(void);
#endif /* SWTPM_OSX */

View File

@ -1,51 +0,0 @@
/*
* osx.c -- OS X specifics
*
* (c) Copyright IBM Corporation 2018.
*
* Author: Stefan Berger <stefanb@us.ibm.com>
*
* All rights reserved.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions are
* met:
*
* Redistributions of source code must retain the above copyright notice,
* this list of conditions and the following disclaimer.
*
* Redistributions in binary form must reproduce the above copyright
* notice, this list of conditions and the following disclaimer in the
* documentation and/or other materials provided with the distribution.
*
* Neither the names of the IBM Corporation nor the names of its
* contributors may be used to endorse or promote products derived from
* this software without specific prior written permission.
*
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
* "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
* LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
* A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
* HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
* SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
* LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
* DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
* THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
* OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
*/
#include "config.h"
#include "osx.h"
#if defined __APPLE__
int daemon(int, int); /* OS X deprecates it */
int osx_daemon(int nochdir, int noclose)
{
return daemon(nochdir, noclose);
}
#endif /* __APPLE__ */

View File

@ -68,7 +68,7 @@
#include "ctrlchannel.h"
#include "tpmstate.h"
#include "sys_dependencies.h"
#include "osx.h"
#include "daemonize.h"
#include "seccomp_profile.h"
#include "options.h"
#include "capabilities.h"
@ -275,6 +275,11 @@ int swtpm_main(int argc, char **argv, const char *prgname, const char *iface)
switch (opt) {
case 'd':
daemonize = TRUE;
if (daemonize_prep() == -1) {
logprintf(STDERR_FILENO,
"Could not prepare to daemonize: %s\n", strerror(errno));
exit(EXIT_FAILURE);
}
break;
case 'p':
@ -485,17 +490,6 @@ int swtpm_main(int argc, char **argv, const char *prgname, const char *iface)
mlp.flags |= MAIN_LOOP_FLAG_TERMINATE | MAIN_LOOP_FLAG_USE_FD;
}
if (daemonize) {
#ifdef __APPLE__
if (0 != osx_daemon(0, 0)) {
#else
if (0 != daemon(0, 0)) {
#endif
logprintf(STDERR_FILENO, "Error: Could not daemonize.\n");
goto exit_failure;
}
}
if (pidfile_write(getpid()) < 0) {
goto exit_failure;
}
@ -526,6 +520,10 @@ int swtpm_main(int argc, char **argv, const char *prgname, const char *iface)
if (create_seccomp_profile(false, seccomp_action) < 0)
goto error_seccomp_profile;
if (daemonize) {
daemonize_finish();
}
rc = mainLoop(&mlp, notify_fd[0]);
error_seccomp_profile:

View File

@ -70,7 +70,7 @@
#include "vtpm_proxy.h"
#endif
#include "tpmstate.h"
#include "osx.h"
#include "daemonize.h"
#include "seccomp_profile.h"
#include "options.h"
#include "capabilities.h"
@ -335,6 +335,11 @@ int swtpm_chardev_main(int argc, char **argv, const char *prgname, const char *i
switch (opt) {
case 'd':
daemonize = TRUE;
if (daemonize_prep() == -1) {
logprintf(STDERR_FILENO,
"Could not prepare to daemonize: %s\n", strerror(errno));
exit(EXIT_FAILURE);
}
break;
case 'c':
@ -534,17 +539,6 @@ int swtpm_chardev_main(int argc, char **argv, const char *prgname, const char *i
goto exit_failure;
}
if (daemonize) {
#if defined __APPLE__
if (0 != osx_daemon(0, 0)) {
#else
if (0 != daemon(0, 0)) {
#endif
logprintf(STDERR_FILENO, "Error: Could not daemonize.\n");
goto exit_failure;
}
}
if (pidfile_write(getpid()) < 0) {
goto exit_failure;
}
@ -578,6 +572,10 @@ int swtpm_chardev_main(int argc, char **argv, const char *prgname, const char *i
mlp.flags |= MAIN_LOOP_FLAG_USE_FD | MAIN_LOOP_FLAG_KEEP_CONNECTION | \
MAIN_LOOP_FLAG_END_ON_HUP;
if (daemonize) {
daemonize_finish();
}
rc = mainLoop(&mlp, notify_fd[0]);
error_seccomp_profile: