HALF WORK: develop SubProcess.

2 files changed, 33 insertions, 5 deletions

diff --git a/include/cru/common/SubProcess.h b/include/cru/common/SubProcess.h
index 9a56b726..0f87b184 100644
--- a/include/cru/common/SubProcess.h
+++ b/include/cru/common/SubProcess.h
@@ -87,8 +87,10 @@ struct SubProcessExitResult {
  * process will be killed.
  */
 class PlatformSubProcessBase : public Object {
+  CRU_DEFINE_CLASS_LOG_TAG(u"PlatformSubProcessBase")
+
  public:
-  explicit PlatformSubProcessBase(const SubProcessStartInfo& start_info);
+  explicit PlatformSubProcessBase(SubProcessStartInfo start_info);
 
   ~PlatformSubProcessBase() override;
 
@@ -141,6 +143,8 @@ class PlatformSubProcessBase : public Object {
   virtual io::Stream* GetStdoutStream() = 0;
   virtual io::Stream* GetStderrStream() = 0;
 
+  void SetDeleteSelfOnExit(bool enable);
+
  protected:
   /**
    * @brief Create and start a real process. If the program can't be created or
@@ -181,6 +185,8 @@ class PlatformSubProcessBase : public Object {
  private:
   SubProcessStatus status_;
 
+  bool delete_self_;
+
   std::thread process_thread_;
   std::mutex process_mutex_;
   std::unique_lock<std::mutex> process_lock_;
@@ -188,16 +194,38 @@ class PlatformSubProcessBase : public Object {
 };
 
 class CRU_BASE_API SubProcess : public Object {
+  CRU_DEFINE_CLASS_LOG_TAG(u"SubProcess")
+
  public:
-  SubProcess();
+  SubProcess(SubProcessStartInfo start_info);
 
   CRU_DELETE_COPY(SubProcess)
 
-  SubProcess(SubProcess&& other);
-  SubProcess& operator=(SubProcess&& other);
+  SubProcess(SubProcess&& other) = default;
+  SubProcess& operator=(SubProcess&& other) = default;
 
   ~SubProcess();
 
+ public:
+  void Wait(std::optional<std::chrono::milliseconds> wait_time);
+  void Kill();
+
+  SubProcessStatus GetStatus();
+  SubProcessExitResult GetExitResult();
+
+  io::Stream* GetStdinStream();
+  io::Stream* GetStdoutStream();
+  io::Stream* GetStderrStream();
+
+  void Detach();
+
+  bool IsValid() const { return platform_process_ != nullptr; }
+  explicit operator bool() const { return IsValid(); }
+
+ private:
+  void CheckValid() const;
+
  private:
+  std::unique_ptr<PlatformSubProcessBase> platform_process_;
 };
 }  // namespace cru
diff --git a/include/cru/common/platform/unix/PosixSpawnSubProcess.h b/include/cru/common/platform/unix/PosixSpawnSubProcess.h
index e8e23738..249b8043 100644
--- a/include/cru/common/platform/unix/PosixSpawnSubProcess.h
+++ b/include/cru/common/platform/unix/PosixSpawnSubProcess.h
@@ -18,7 +18,7 @@ class PosixSpawnSubProcess : public PlatformSubProcessBase {
   CRU_DEFINE_CLASS_LOG_TAG(u"PosixSpawnSubProcess")
 
  public:
-  explicit PosixSpawnSubProcess(const SubProcessStartInfo& start_info);
+  explicit PosixSpawnSubProcess(SubProcessStartInfo start_info);
   ~PosixSpawnSubProcess();
 
   io::Stream* GetStdinStream() override;