summaryrefslogtreecommitdiff
path: root/test
AgeCommit message (Expand)Author
2021-09-15test: serialization: Prevent parallelisationKieran Bingham
2021-09-10test: v4l2_compat_test: Fix v4l2-compliance version parsingPaul Elder
2021-09-09test: gstreamer: Fix the destructor of GstreamerTest base classVedant Paranjape
2021-09-08test: gstreamer: Factor out code into a base classVedant Paranjape
2021-09-07libcamera: v4l2_videodevice: Drop toV4L2PixelFormat()Laurent Pinchart
2021-09-07libcamera: base: utils: Use size_t for index in utils::enumerate()Laurent Pinchart
2021-09-02libcamera: Drop emitter object pointer from signal argumentsLaurent Pinchart
2021-09-02libcamera: Don't use emitter object pointer argument to slotLaurent Pinchart
2021-09-02libcamera: base: signal: Support connecting signals to functorsLaurent Pinchart
2021-09-02libcamera: Use simpler Signal::disconnect() functionLaurent Pinchart
2021-09-01test: v4l2_compat: Disable test when ASan is enabledLaurent Pinchart
2021-08-31libcamera: camera_sensor: Transform CameraSensor::sizes()Umang Jain
2021-08-26test: gstreamer: Disable gstreamer registry forksVedant Paranjape
2021-08-26test: gstreamer: Clean up memory managementVedant Paranjape
2021-08-19ipa: Use FileDescriptor instead of int in layers above IPC payloadPaul Elder
2021-08-19test: camera: Camera reconfiguration and fd-leak testUmang Jain
2021-08-19libtest: camera_test: Plumb constructor to set LIBCAMERA_IPA_FORCE_ISOLATIONUmang Jain
2021-08-14test: gstreamer: Add test for gstreamer single streamVedant Paranjape
2021-08-12test: control serialization: Test lookup by ControlIdJacopo Mondi
2021-08-12libcamera: controls: Create ControlInfoMap with ControlIdMapJacopo Mondi
2021-08-10libcamera: MappedFrameBuffer: Use typed Flags<MapModes>Kieran Bingham
2021-08-10libcamera: Give MappedFrameBuffer its own implementationKieran Bingham
2021-08-09libcamera: Rename 'method' to 'function'Laurent Pinchart
2021-08-03libcamera: file: Turn MapFlag and OpenModeFlag into enum classLaurent Pinchart
2021-08-03test: Add tests for the Flags classLaurent Pinchart
2021-08-02controls: Add boolean constructors for ControlInfoPaul Elder
2021-07-11libcamera: buffer: Rename buffer.h to framebuffer.hLaurent Pinchart
2021-07-11test: message: Test recursive Thread::dispatchMessages() callsLaurent Pinchart
2021-07-06libcamera: camera: Make stop() idempotentNícolas F. R. A. Prado
2021-06-25test: Ensure LIBCAMERA_BASE_PRIVATE isn't publicKieran Bingham
2021-06-25libcamera: rename public libcamera dependencyKieran Bingham
2021-06-25libcamera/base: Validate internal headers as privateKieran Bingham
2021-06-25libcamera/base: Move span to base libraryKieran Bingham
2021-06-25libcamera/base: Move event_notifier to baseKieran Bingham
2021-06-25libcamera/base: Move File to base libraryKieran Bingham
2021-06-25libcamera/base: Move extended base functionalityKieran Bingham
2021-06-25libcamera/base: Move utils to the base libraryKieran Bingham
2021-06-08libcamera: utils: Add helper class for std::chrono::durationNaushir Patuck
2021-05-26test: v4l2_videodevice: controls: Test 64-bit controlsLaurent Pinchart
2021-05-26test: byte-stream-buffer: Initialize data arrayNiklas Söderlund
2021-05-18libcamera: utils: Add enumerate view for range-based for loopsLaurent Pinchart
2021-05-06test: control_list: Test ControlList::merge()Jacopo Mondi
2021-05-06test: control_list: Check for Brightness presenceJacopo Mondi
2021-05-05test: bayer-format: Rectify internal header's #include pathUmang Jain
2021-04-15test: span: Add tests for begin() and rbegin()Laurent Pinchart
2021-04-12test: threads: Fix memory leakLaurent Pinchart
2021-03-28meson: Summarize which applications and adaptation layers are builtLaurent Pinchart
2021-03-23ipa: Add sensor model string to IPASettingsNaushir Patuck
2021-03-12test: delayed_controls: Rename delayed_contols.cpp to delayed_controls.cppNaushir Patuck
2021-03-12test: delayed_controls: Fixup tests after recent DelayedControls changesNaushir Patuck
generated by cgit v1.2.1 (git 2.18.0) at 2025-02-28 00:53:23 +0000
G_IGN && oldsa.sa_handler != SIG_DFL) oldsa.sa_handler(signal); } } } /* namespace */ void ProcessManager::sighandler() { char data; ssize_t ret = read(pipe_[0], &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); if (pipe2(pipe_, O_CLOEXEC | O_DIRECT | O_NONBLOCK)) LOG(Process, Fatal) << "Failed to initialize pipe for signal handling"; sigEvent_ = new EventNotifier(pipe_[0], EventNotifier::Read); sigEvent_->activated.connect(this, &ProcessManager::sighandler); self_ = this; } ProcessManager::~ProcessManager() { sigaction(SIGCHLD, &oldsa_, NULL); delete sigEvent_; close(pipe_[0]); close(pipe_[1]); 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]; } /** * \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); 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 */
generated by cgit v1.2.1 (git 2.18.0) at 2025-02-28 00:53:23 +0000