src/qcam/main_window.h

/* SPDX-License-Identifier: LGPL-2.1-or-later */
/*
 * Copyright (C) 2019, Google Inc.
 *
 * Process object
 */

#include "libcamera/internal/process.h"

#include <algorithm>
#include <dirent.h>
#include <fcntl.h>
#include <iostream>
#include <list>
#include <signal.h>
#include <string.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <sys/wait.h>
#include <unistd.h>
#include <vector>

#include <libcamera/base/event_notifier.h>
#include <libcamera/base/log.h>
#include <libcamera/base/utils.h>

/**
 * \file process.h
 * \brief Process object
 */

namespace libcamera {

LOG_DEFINE_CATEGORY(Process)

/**
 * \class ProcessManager
 * \brief Manager of processes
 *
 * The ProcessManager singleton keeps track of all created Process instances,
 * and manages the signal handling involved in terminating processes.
 */

namespace {

void sigact(int signal, siginfo_t *info, void *ucontext)
{
#pragma GCC diagnostic push
#pragma GCC diagnostic ignored "-Wunused-result"
	/*
	 * We're in a signal handler so we can't log any message, and we need
	 * to continue anyway.
	 */
	char data = 0;
	write(ProcessManager::instance()->writePipe(), &data, sizeof(data));
#pragma GCC diagnostic pop

	const struct sigaction &oldsa = ProcessManager::instance()->oldsa();
	if (oldsa.sa_flags & SA_SIGINFO) {
		oldsa.sa_sigaction(signal, info, ucontext);
	} else {
		if (oldsa.sa_handler != SIG_IGN && oldsa.sa_handler != SIG_DFL)
			oldsa.sa_handler(signal);
	}
}

} /* namespace */

void ProcessManager::sighandler()
{
	char data;
	ssize_t ret = read(pipe_[0].get(), &data, sizeof(data));
	if (ret < 0) {
		LOG(Process, Error)
			<< "Failed to read byte from signal handler pipe";
		return;
	}

	for (auto it = processes_.begin(); it != processes_.end(); ) {
		Process *process = *it;

		int wstatus;
		pid_t pid = waitpid(process->pid_, &wstatus, WNOHANG);
		if (process->pid_ != pid) {
			++it;
			continue;
		}

		it = processes_.erase(it);
		process->died(wstatus);
	}
}

/**
 * \brief Register process with process manager
 * \param[in] proc Process to register
 *
 * This function registers the \a proc with the process manager. It
 * shall be called by the parent process after successfully forking, in
 * order to let the parent signal process termination.
 */
void ProcessManager::registerProcess(Process *proc)
{
	processes_.push_back(proc);
}

ProcessManager *ProcessManager::self_ = nullptr;

/**
 * \brief Construct a ProcessManager instance
 *
 * The ProcessManager class is meant to only be instantiated once, by the
 * CameraManager.
 */
ProcessManager::ProcessManager()
{
	if (self_)
		LOG(Process, Fatal)
			<< "Multiple ProcessManager objects are not allowed";

	sigaction(SIGCHLD, NULL, &oldsa_);

	struct sigaction sa;
	memset(&sa, 0, sizeof(sa));
	sa.sa_sigaction = &sigact;
	memcpy(&sa.sa_mask, &oldsa_.sa_mask, sizeof(sa.sa_mask));
	sigaddset(&sa.sa_mask, SIGCHLD);
	sa.sa_flags = oldsa_.sa_flags | SA_SIGINFO;

	sigaction(SIGCHLD, &sa, NULL);

	int pipe[2];
	if (pipe2(pipe, O_CLOEXEC | O_DIRECT | O_NONBLOCK))
		LOG(Process, Fatal)
			<< "Failed to initialize pipe for signal handling";

	pipe_[0] = UniqueFD(pipe[0]);
	pipe_[1] = UniqueFD(pipe[1]);

	sigEvent_ = new EventNotifier(pipe_[0].get(), EventNotifier::Read);
	sigEvent_->activated.connect(this, &ProcessManager::sighandler);

	self_ = this;
}

ProcessManager::~ProcessManager()
{
	sigaction(SIGCHLD, &oldsa_, NULL);

	delete sigEvent_;

	self_ = nullptr;
}

/**
 * \brief Retrieve the Process manager instance
 *
 * The ProcessManager is constructed by the CameraManager. This function shall
 * be used to retrieve the single instance of the manager.
 *
 * \return The Process manager instance
 */
ProcessManager *ProcessManager::instance()
{
	return self_;
}

/**
 * \brief Retrieve the Process manager's write pipe
 *
 * This function is meant only to be used by the static signal handler.
 *
 * \return Pipe for writing
 */
int ProcessManager::writePipe() const
{
	return pipe_[1].get();
}

/**
 * \brief Retrive the old signal action data
 *
 * This function is meant only to be used by the static signal handler.
 *
 * \return The old signal action data
 */
const struct sigaction &ProcessManager::oldsa() const
{
	return oldsa_;
}


/**
 * \class Process
 * \brief Process object
 *
 * The Process class models a process, and simplifies spawning new processes
 * and monitoring the exiting of a process.
 */

/**
 * \enum Process::ExitStatus
 * \brief Exit status of process
 * \var Process::NotExited
 * The process hasn't exited yet
 * \var Process::NormalExit
 * The process exited normally, either via exit() or returning from main
 * \var Process::SignalExit
 * The process was terminated by a signal (this includes crashing)
 */

Process::Process()
	: pid_(-1), running_(false), exitStatus_(NotExited), exitCode_(0)
{
}

Process::~Process()
{
	kill();
	/* \todo wait for child process to exit */
}

/**
 * \brief Fork and exec a process, and close fds
 * \param[in] path Path to executable
 * \param[in] args Arguments to pass to executable (optional)
 * \param[in] fds Vector of file descriptors to keep open (optional)
 *
 * Fork a process, and exec the executable specified by path. Prior to
 * exec'ing, but after forking, all file descriptors except for those
 * specified in fds will be closed.
 *
 * All indexes of args will be incremented by 1 before being fed to exec(),
 * so args[0] should not need to be equal to path.
 *
 * \return Zero on successful fork, exec, and closing the file descriptors,
 * or a negative error code otherwise
 */
int Process::start(const std::string &path,
		   const std::vector<std::string> &args,
		   const std::vector<int> &fds)
{
	int ret;

	if (running_)
		return 0;

	int childPid = fork();
	if (childPid == -1) {
		ret = -errno;
		LOG(Process, Error) << "Failed to fork: " << strerror(-ret);
		return ret;
	} else if (childPid) {
		pid_ = childPid;
		ProcessManager::instance()->registerProcess(this);

		running_ = true;

		return 0;
	} else {
		if (isolate())
			_exit(EXIT_FAILURE);

		closeAllFdsExcept(fds);

		const char *file = utils::secure_getenv("LIBCAMERA_LOG_FILE");
		if (file && strcmp(file, "syslog"))
			unsetenv("LIBCAMERA_LOG_FILE");

		const char **argv = new const char *[args.size() + 2];
		unsigned int len = args.size();
		argv[0] = path.c_str();
		for (unsigned int i = 0; i < len; i++)
			argv[i+1] = args[i].c_str();
		argv[len+1] = nullptr;

		execv(path.c_str(), (char **)argv);

		exit(EXIT_FAILURE);
	}
}

void Process::closeAllFdsExcept(const std::vector<int> &fds)
{
	std::vector<int> v(fds);
	sort(v.begin(), v.end());

	DIR *dir = opendir("/proc/self/fd");
	if (!dir)
		return;

	int dfd = dirfd(dir);

	struct dirent *ent;
	while ((ent = readdir(dir)) != nullptr) {
		char *endp;
		int fd = strtoul(ent->d_name, &endp, 10);
		if (*endp)
			continue;

		if (fd >= 0 && fd != dfd &&
		    !std::binary_search(v.begin(), v.end(), fd))
			close(fd);
	}

	closedir(dir);
}

int Process::isolate()
{
	int ret = unshare(CLONE_NEWUSER | CLONE_NEWNET);
	if (ret) {
		ret = -errno;
		LOG(Process, Error) << "Failed to unshare execution context: "
				    << strerror(-ret);
		return ret;
	}

	return 0;
}

/**
 * \brief SIGCHLD handler
 * \param[in] wstatus The status as output by waitpid()
 *
 * This function is called when the process associated with Process terminates.
 * It emits the Process::finished signal.
 */
void Process::died(int wstatus)
{
	running_ = false;
	exitStatus_ = WIFEXITED(wstatus) ? NormalExit : SignalExit;
	exitCode_ = exitStatus_ == NormalExit ? WEXITSTATUS(wstatus) : -1;

	finished.emit(exitStatus_, exitCode_);
}

/**
 * \fn Process::exitStatus()
 * \brief Retrieve the exit status of the process
 *
 * Return the exit status of the process, that is, whether the process
 * has exited via exit() or returning from main, or if the process was
 * terminated by a signal.
 *
 * \sa ExitStatus
 *
 * \return The process exit status
 */

/**
 * \fn Process::exitCode()
 * \brief Retrieve the exit code of the process
 *
 * This function is only valid if exitStatus() returned NormalExit.
 *
 * \return Exit code
 */

/**
 * \var Process::finished
 *
 * Signal that is emitted when the process is confirmed to have terminated.
 */

/**
 * \brief Kill the process
 *
 * Sends SIGKILL to the process.
 */
void Process::kill()
{
	if (pid_ > 0)
		::kill(pid_, SIGKILL);
}

} /* namespace libcamera */
Age	Commit message (Expand)	Author
2021-07-11	libcamera: buffer: Rename buffer.h to framebuffer.h	Laurent Pinchart
2020-12-01	qcam: Make log less verbose by default	Laurent Pinchart
2020-10-12	libcamera, android, cam, gstreamer, qcam, v4l2: Reuse Request	Paul Elder
2020-09-15	qcam: Add additional command line option to select the renderer type	Show Liu
2020-08-14	libcamera: request: Make Stream pointer const	Niklas Söderlund
2020-08-14	libcamera: request: Declare a using directive for map of buffers	Niklas Söderlund
2020-06-17	qcam: main_window: Introduce initial hotplug support	Umang Jain
2020-05-03	qcam: Pass request metadata to DNG writer	Laurent Pinchart
2020-05-02	qcam: Add RAW capture support	Niklas Söderlund
2020-05-02	qcam: Allow for a second raw stream to be configured	Niklas Söderlund
2020-05-01	qcam: Make use of StreamKeyValueParser	Niklas Söderlund
2020-04-30	qcam: main_window: Make cameraCombo_ private	Umang Jain
2020-03-24	qcam: viewfinder: Make the viewfinder hold a reference to a buffer	Laurent Pinchart
2020-03-24	qcam: viewfinder: Move multi-planar check into viewfinder	Laurent Pinchart
2020-03-24	qcam: viewfinder: Add MappedBuffer to store memory mapping information	Laurent Pinchart
2020-03-24	qcam: main_window: Document functions and reorganize member data	Laurent Pinchart
2020-03-24	qcam: main_window: Replace start and stop actions with a toggle action	Laurent Pinchart
2020-03-24	qcam: main_window: Move capture event processing to main thread	Laurent Pinchart
2020-03-24	qcam: main_window: Move request queuing to a separate function	Laurent Pinchart
2020-02-14	qcam: Provide save image functionality	Kieran Bingham
2020-02-14	qcam: Provide initial icon buttons "Play/Stop"	Kieran Bingham
2020-02-14	qcam: Introduce a toolbar and camera switching	Kieran Bingham
2020-02-14	qcam: Store CameraManager as class member	Kieran Bingham
2020-01-12	qcam: Cache buffer memory mapping	Niklas Söderlund
2020-01-12	libcamera: Switch to FrameBuffer interface	Niklas Söderlund
2019-11-19	libcamera: camera: Remove explicit stream to buffer map in requestCompleted s...	Niklas Söderlund
2019-10-25	qcam: Don't ask for a camera when only one exists	Kieran Bingham
2019-08-19	qcam: Pass camera manager to MainWindow class	Laurent Pinchart
2019-07-17	libcamera: qcam: Allow specifying sizes on command line	Jacopo Mondi
2019-07-14	libcamera: buffer: Add an accessor to the BufferMemory	Laurent Pinchart
2019-07-14	libcamera: buffer: Split memory information to BufferMemory	Laurent Pinchart
2019-07-04	qcam: Update window title with FPS	Kieran Bingham
2019-07-04	qcam: Add the version string to the title	Kieran Bingham
2019-07-04	qcam: Move static timestamp to MainWindow	Kieran Bingham
2019-05-23	libcamera: camera: Return a pointer from generateConfiguration()	Laurent Pinchart
2019-05-23	libcamera: camera: Rename configureStreams() and streamConfiguration()	Laurent Pinchart
2019-04-09	libcamera: Switch to CameraConfiguration	Niklas Söderlund
2019-03-29	qcam: Add Qt-based GUI application	Laurent Pinchart