libcamera: ProcessManager: make ProcessManager lifetime explicitly managed

If any Process instances are destroyed after the ProcessManager is
destroyed, then a segfault will occur.

Fix this by making the lifetime of the ProcessManager explicit, and make
the CameraManager construct and deconstruct (automatically, via a member
variable) the ProcessManager.

Update the tests accordingly.

Signed-off-by: Paul Elder <paul.elder@ideasonboard.com>
Reviewed-by: Laurent Pinchart <laurent.pinchart@ideasonboard.com>
Reviewed-by: Niklas Söderlund <niklas.soderlund@ragnatech.se>
Reviewed-by: Jacopo Mondi <jacopo@jmondi.org>
This commit is contained in:
Paul Elder 2020-08-26 17:26:47 +09:00
parent 7e59bccb35
commit 1469d5e26e
5 changed files with 54 additions and 27 deletions

View file

@ -7,6 +7,7 @@
#ifndef __LIBCAMERA_INTERNAL_PROCESS_H__ #ifndef __LIBCAMERA_INTERNAL_PROCESS_H__
#define __LIBCAMERA_INTERNAL_PROCESS_H__ #define __LIBCAMERA_INTERNAL_PROCESS_H__
#include <signal.h>
#include <string> #include <string>
#include <vector> #include <vector>
@ -14,6 +15,8 @@
namespace libcamera { namespace libcamera {
class EventNotifier;
class Process final class Process final
{ {
public: public:
@ -50,6 +53,32 @@ private:
friend class ProcessManager; friend class ProcessManager;
}; };
class ProcessManager
{
public:
ProcessManager();
~ProcessManager();
void registerProcess(Process *proc);
static ProcessManager *instance();
int writePipe() const;
const struct sigaction &oldsa() const;
private:
static ProcessManager *self_;
void sighandler(EventNotifier *notifier);
std::list<Process *> processes_;
struct sigaction oldsa_;
EventNotifier *sigEvent_;
int pipe_[2];
};
} /* namespace libcamera */ } /* namespace libcamera */
#endif /* __LIBCAMERA_INTERNAL_PROCESS_H__ */ #endif /* __LIBCAMERA_INTERNAL_PROCESS_H__ */

View file

@ -18,6 +18,7 @@
#include "libcamera/internal/ipa_manager.h" #include "libcamera/internal/ipa_manager.h"
#include "libcamera/internal/log.h" #include "libcamera/internal/log.h"
#include "libcamera/internal/pipeline_handler.h" #include "libcamera/internal/pipeline_handler.h"
#include "libcamera/internal/process.h"
#include "libcamera/internal/thread.h" #include "libcamera/internal/thread.h"
#include "libcamera/internal/utils.h" #include "libcamera/internal/utils.h"
@ -67,6 +68,7 @@ private:
std::unique_ptr<DeviceEnumerator> enumerator_; std::unique_ptr<DeviceEnumerator> enumerator_;
IPAManager ipaManager_; IPAManager ipaManager_;
ProcessManager processManager_;
}; };
CameraManager::Private::Private(CameraManager *cm) CameraManager::Private::Private(CameraManager *cm)

View file

@ -41,28 +41,6 @@ LOG_DEFINE_CATEGORY(Process)
* The ProcessManager singleton keeps track of all created Process instances, * The ProcessManager singleton keeps track of all created Process instances,
* and manages the signal handling involved in terminating processes. * and manages the signal handling involved in terminating processes.
*/ */
class ProcessManager
{
public:
void registerProcess(Process *proc);
static ProcessManager *instance();
int writePipe() const;
const struct sigaction &oldsa() const;
private:
void sighandler(EventNotifier *notifier);
ProcessManager();
~ProcessManager();
std::list<Process *> processes_;
struct sigaction oldsa_;
EventNotifier *sigEvent_;
int pipe_[2];
};
namespace { namespace {
@ -127,8 +105,20 @@ void ProcessManager::registerProcess(Process *proc)
processes_.push_back(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() ProcessManager::ProcessManager()
{ {
if (self_)
LOG(Process, Fatal)
<< "Multiple ProcessManager objects are not allowed";
sigaction(SIGCHLD, NULL, &oldsa_); sigaction(SIGCHLD, NULL, &oldsa_);
struct sigaction sa; struct sigaction sa;
@ -145,6 +135,8 @@ ProcessManager::ProcessManager()
<< "Failed to initialize pipe for signal handling"; << "Failed to initialize pipe for signal handling";
sigEvent_ = new EventNotifier(pipe_[0], EventNotifier::Read); sigEvent_ = new EventNotifier(pipe_[0], EventNotifier::Read);
sigEvent_->activated.connect(this, &ProcessManager::sighandler); sigEvent_->activated.connect(this, &ProcessManager::sighandler);
self_ = this;
} }
ProcessManager::~ProcessManager() ProcessManager::~ProcessManager()
@ -153,21 +145,21 @@ ProcessManager::~ProcessManager()
delete sigEvent_; delete sigEvent_;
close(pipe_[0]); close(pipe_[0]);
close(pipe_[1]); close(pipe_[1]);
self_ = nullptr;
} }
/** /**
* \brief Retrieve the Process manager instance * \brief Retrieve the Process manager instance
* *
* The ProcessManager is a singleton and can't be constructed manually. This * The ProcessManager is constructed by the CameraManager. This function shall
* method shall instead be used to retrieve the single global instance of the * be used to retrieve the single instance of the manager.
* manager.
* *
* \return The Process manager instance * \return The Process manager instance
*/ */
ProcessManager *ProcessManager::instance() ProcessManager *ProcessManager::instance()
{ {
static ProcessManager processManager; return self_;
return &processManager;
} }
/** /**

View file

@ -132,6 +132,8 @@ private:
exitCode_ = exitCode; exitCode_ = exitCode;
} }
ProcessManager processManager_;
Process proc_; Process proc_;
Process::ExitStatus exitStatus_; Process::ExitStatus exitStatus_;
string logPath_; string logPath_;

View file

@ -87,6 +87,8 @@ private:
exitCode_ = exitCode; exitCode_ = exitCode;
} }
ProcessManager processManager_;
Process proc_; Process proc_;
enum Process::ExitStatus exitStatus_; enum Process::ExitStatus exitStatus_;
int exitCode_; int exitCode_;