src/machine/operation.c

   1 /***
   2   This file is part of systemd.
   3
   4   Copyright 2016 Lennart Poettering
   5
   6   systemd is free software; you can redistribute it and/or modify it
   7   under the terms of the GNU Lesser General Public License as published by
   8   the Free Software Foundation; either version 2.1 of the License, or
   9   (at your option) any later version.
  10
  11   systemd is distributed in the hope that it will be useful, but
  12   WITHOUT ANY WARRANTY; without even the implied warranty of
  13   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
  14   Lesser General Public License for more details.
  15
  16   You should have received a copy of the GNU Lesser General Public License
  17   along with systemd; If not, see <http://www.gnu.org/licenses/>.
  18 ***/
  19
  20 #include "alloc-util.h"
  21 #include "fd-util.h"
  22 #include "operation.h"
  23 #include "process-util.h"
  24
  25 static int operation_done(sd_event_source *s, const siginfo_t *si, void *userdata) {
  26         _cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL;
  27         Operation *o = userdata;
  28         int r;
  29
  30         assert(o);
  31         assert(si);
  32
  33         log_debug("Operating " PID_FMT " is now complete with with code=%s status=%i",
  34                   o->pid,
  35                   sigchld_code_to_string(si->si_code), si->si_status);
  36
  37         o->pid = 0;
  38
  39         if (si->si_code != CLD_EXITED) {
  40                 r = sd_bus_error_setf(&error, SD_BUS_ERROR_FAILED, "Child died abnormally.");
  41                 goto fail;
  42         }
  43
  44         if (si->si_status != EXIT_SUCCESS) {
  45                 if (read(o->errno_fd, &r, sizeof(r)) == sizeof(r))
  46                         r = sd_bus_error_set_errnof(&error, r, "%m");
  47                 else
  48                         r = sd_bus_error_setf(&error, SD_BUS_ERROR_FAILED, "Child failed.");
  49
  50                 goto fail;
  51         }
  52
  53         r = sd_bus_reply_method_return(o->message, NULL);
  54         if (r < 0)
  55                 log_error_errno(r, "Failed to reply to message: %m");
  56
  57         operation_free(o);
  58         return 0;
  59
  60 fail:
  61         r = sd_bus_reply_method_error(o->message, &error);
  62         if (r < 0)
  63                 log_error_errno(r, "Failed to reply to message: %m");
  64
  65         operation_free(o);
  66         return 0;
  67 }
  68
  69 int operation_new(Manager *m, pid_t child, sd_bus_message *message, int errno_fd) {
  70         Operation *o;
  71         int r;
  72
  73         o = new0(Operation, 1);
  74         if (!o)
  75                 return -ENOMEM;
  76
  77         r = sd_event_add_child(m->event, &o->event_source, child, WEXITED, operation_done, o);
  78         if (r < 0) {
  79                 free(o);
  80                 return r;
  81         }
  82
  83         o->pid = child;
  84         o->message = sd_bus_message_ref(message);
  85         o->errno_fd = errno_fd;
  86
  87         LIST_PREPEND(operations, m->operations, o);
  88         m->n_operations++;
  89         o->manager = m;
  90
  91         log_debug("Started new operation " PID_FMT ".", child);
  92
  93         /* At this point we took ownership of both the child and the errno file descriptor! */
  94
  95         return 0;
  96 }
  97
  98 Operation *operation_free(Operation *o) {
  99         if (!o)
 100                 return NULL;
 101
 102         sd_event_source_unref(o->event_source);
 103
 104         safe_close(o->errno_fd);
 105
 106         if (o->pid > 1)
 107                 (void) sigkill_wait(&o->pid);
 108
 109         sd_bus_message_unref(o->message);
 110
 111         if (o->manager) {
 112                 LIST_REMOVE(operations, o->manager->operations, o);
 113                 o->manager->n_operations--;
 114         }
 115
 116         free(o);
 117         return NULL;
 118 }