Refactoring: split out exec_succeeded function.

The status pipe watcher (exec_status_pipe_watcher) had some
service-record-type specific code. Split it out as a virtual function.

diff --git a/src/proc-service.cc b/src/proc-service.cc
index c0efb5235a3b1973efc2df83cfa71937d9795337..9e64eecc6e193062d4e0fea55ab9eae19509b25f 100644 (file)
--- a/src/proc-service.cc
+++ b/src/proc-service.cc
@@ -35,6 +35,24 @@ std::vector<const char *> separate_args(std::string &s, std::list<std::pair<unsi
     return r;
 }
 
+void process_service::exec_succeeded() noexcept
+{
+    // This could be a smooth recovery (state already STARTED). Even more, the process
+    // might be stopped (and killed via a signal) during smooth recovery.  We don't to
+    // process startup again in either case, so we check for state STARTING:
+    if (get_state() == service_state_t::STARTING) {
+        started();
+    }
+    else if (get_state() == service_state_t::STOPPING) {
+        // stopping, but smooth recovery was in process. That's now over so we can
+        // commence normal stop. Note that if pid == -1 the process already stopped(!),
+        // that's handled below.
+        if (pid != -1 && stop_check_dependents()) {
+            bring_down();
+        }
+    }
+}
+
 rearm exec_status_pipe_watcher::fd_event(eventloop_t &loop, int fd, int flags) noexcept
 {
     base_process_service *sr = service;
@@ -59,26 +77,10 @@ rearm exec_status_pipe_watcher::fd_event(eventloop_t &loop, int fd, int flags) n
         sr->exec_failed(exec_status);
     }
     else {
-        // exec() succeeded.
-        if (sr->get_type() == service_type_t::PROCESS) {
-            // This could be a smooth recovery (state already STARTED). Even more, the process
-            // might be stopped (and killed via a signal) during smooth recovery.  We don't to
-            // process startup again in either case, so we check for state STARTING:
-            if (sr->get_state() == service_state_t::STARTING) {
-                sr->started();
-            }
-            else if (sr->get_state() == service_state_t::STOPPING) {
-                // stopping, but smooth recovery was in process. That's now over so we can
-                // commence normal stop. Note that if pid == -1 the process already stopped(!),
-                // that's handled below.
-                if (sr->pid != -1 && sr->stop_check_dependents()) {
-                    sr->bring_down();
-                }
-            }
-        }
+        sr->exec_succeeded();
 
         if (sr->pid == -1) {
-            // Somehow the process managed to complete before we even saw the status.
+            // Somehow the process managed to complete before we even saw the exec() status.
             sr->handle_exit_status(sr->exit_status);
         }
     }

diff --git a/src/proc-service.h b/src/proc-service.h
index c23b997751c45fa9ecfda27417f64a876cab54a7..d32938f53629374483cf08e50a68003121aa39f2 100644 (file)
--- a/src/proc-service.h
+++ b/src/proc-service.h
@@ -88,6 +88,9 @@ class base_process_service : public service_record
     // Called if an exec fails.
     virtual void exec_failed(int errcode) noexcept = 0;
 
+    // Called if exec succeeds.
+    virtual void exec_succeeded() noexcept { };
+
     virtual bool can_interrupt_start() noexcept override
     {
         return waiting_restart_timer || start_is_interruptible || service_record::can_interrupt_start();
@@ -153,6 +156,7 @@ class process_service : public base_process_service
 {
     virtual void handle_exit_status(int exit_status) noexcept override;
     virtual void exec_failed(int errcode) noexcept override;
+    virtual void exec_succeeded() noexcept override;
     virtual void bring_down() noexcept override;
 
     public: