aboutsummaryrefslogtreecommitdiff
path: root/src/libutil
diff options
context:
space:
mode:
Diffstat (limited to 'src/libutil')
-rw-r--r--src/libutil/util.cc31
-rw-r--r--src/libutil/util.hh12
2 files changed, 33 insertions, 10 deletions
diff --git a/src/libutil/util.cc b/src/libutil/util.cc
index 305e470eb..bdd114c5e 100644
--- a/src/libutil/util.cc
+++ b/src/libutil/util.cc
@@ -863,31 +863,46 @@ void killUser(uid_t uid)
//////////////////////////////////////////////////////////////////////
-pid_t startProcess(std::function<void()> fun,
- bool dieWithParent, const string & errorPrefix, bool runExitHandlers)
+/* Wrapper around vfork to prevent the child process from clobbering
+ the caller's stack frame in the parent. */
+static pid_t doFork(bool allowVfork, std::function<void()> fun) __attribute__((noinline));
+static pid_t doFork(bool allowVfork, std::function<void()> fun)
{
+#ifdef __linux__
+ pid_t pid = allowVfork ? vfork() : fork();
+#else
pid_t pid = fork();
- if (pid == -1) throw SysError("unable to fork");
+#endif
+ if (pid != 0) return pid;
+ fun();
+ abort();
+}
- if (pid == 0) {
+
+pid_t startProcess(std::function<void()> fun, const ProcessOptions & options)
+{
+ auto wrapper = [&]() {
_writeToStderr = 0;
try {
#if __linux__
- if (dieWithParent && prctl(PR_SET_PDEATHSIG, SIGKILL) == -1)
+ if (options.dieWithParent && prctl(PR_SET_PDEATHSIG, SIGKILL) == -1)
throw SysError("setting death signal");
#endif
restoreAffinity();
fun();
} catch (std::exception & e) {
try {
- std::cerr << errorPrefix << e.what() << "\n";
+ std::cerr << options.errorPrefix << e.what() << "\n";
} catch (...) { }
} catch (...) { }
- if (runExitHandlers)
+ if (options.runExitHandlers)
exit(1);
else
_exit(1);
- }
+ };
+
+ pid_t pid = doFork(options.allowVfork, wrapper);
+ if (pid == -1) throw SysError("unable to fork");
return pid;
}
diff --git a/src/libutil/util.hh b/src/libutil/util.hh
index 628b8a0e1..09eb4d6e2 100644
--- a/src/libutil/util.hh
+++ b/src/libutil/util.hh
@@ -269,8 +269,16 @@ void killUser(uid_t uid);
/* Fork a process that runs the given function, and return the child
pid to the caller. */
-pid_t startProcess(std::function<void()> fun, bool dieWithParent = true,
- const string & errorPrefix = "error: ", bool runExitHandlers = false);
+struct ProcessOptions
+{
+ string errorPrefix;
+ bool dieWithParent;
+ bool runExitHandlers;
+ bool allowVfork;
+ ProcessOptions() : errorPrefix("error: "), dieWithParent(true), runExitHandlers(false), allowVfork(true) { };
+};
+
+pid_t startProcess(std::function<void()> fun, const ProcessOptions & options = ProcessOptions());
/* Run a program and return its stdout in a string (i.e., like the