SIGTERM and wait for subprocesses on server shutdown.

diff --git a/lib/event.c b/lib/event.c
index ee25024c594369c8818471dd6b2b07a5a2ed778f..0c1e99a5cb8319d1ef40a25c7e6601aadef9630d 100644 (file)
--- a/lib/event.c
+++ b/lib/event.c
@@ -754,6 +754,38 @@ int ev_child_cancel(ev_source *ev,
   return 0;
 }
 
+/** @brief Terminate and wait for all child processes
+ * @param ev Event loop
+ *
+ * Does *not* call the completion callbacks.  Only used during teardown.
+ */
+void ev_child_killall(ev_source *ev) {
+  int n, rc, w;
+
+  for(n = 0; n < ev->nchildren; ++n) {
+    if(kill(ev->children[n].pid, SIGTERM) < 0) {
+      error(errno, "sending SIGTERM to pid %lu",
+           (unsigned long)ev->children[n].pid);
+      ev->children[n].pid = -1;
+    } else
+      info("sent SIGTERM to pid %lu", (unsigned long)ev->children[n].pid);
+  }
+  for(n = 0; n < ev->nchildren; ++n) {
+    if(ev->children[n].pid == -1)
+      continue;
+    do {
+      rc = waitpid(ev->children[n].pid, &w, 0);
+    } while(rc < 0 && errno == EINTR);
+    if(rc < 0) {
+      error(errno, "waiting for pid %lu", (unsigned long)ev->children[n].pid);
+      continue;
+    }
+    info("pid %lu exited with status %#x",
+        (unsigned long)ev->children[n].pid, w);
+  }
+  ev->nchildren = 0;
+}
+
 /* socket listeners ***********************************************************/
 
 /** @brief State for a socket listener */

diff --git a/lib/event.h b/lib/event.h
index 2838c41412f994387ddcca4ad3e09bc2304969ea..113666c8fd4106de9278fbe1b0830d4a814b5d5e 100644 (file)
--- a/lib/event.h
+++ b/lib/event.h
@@ -139,6 +139,8 @@ int ev_child_cancel(ev_source *ev,
                    pid_t pid);
 /* cancel a child callback. */
 
+void ev_child_killall(ev_source *ev);
+
 /* socket listeners ***********************************************************/
 
 typedef int ev_listen_callback(ev_source *ev,

diff --git a/server/state.c b/server/state.c
index bd74b149f2fb977c22461243ddf201af38cfc3fe..47bb75c57624d68ec2b69c6790bd27b374c87682 100644 (file)
--- a/server/state.c
+++ b/server/state.c
@@ -50,6 +50,22 @@ void quit(ev_source *ev) {
   quitting(ev);
   trackdb_close();
   trackdb_deinit();
+  /* Shutdown subprocesses.
+   *
+   * Subprocesses that use ev_child:
+   * - the speaker
+   * - the current rescan
+   * - any decoders
+   * - ...and players
+   * - the track picker
+   * - mail sender
+   * - the deadlock manager
+   *
+   * Subprocesses that don't:
+   * - any normalizers
+   * These are not shut down currently.
+   */
+  ev_child_killall(ev);
   info("exiting");
   exit(0);
 }