/mandos/release

To get this branch, use:
bzr branch http://bzr.recompile.se/loggerhead/mandos/release

« back to all changes in this revision

Viewing changes to plugin-runner.c

First version of a somewhat complete D-Bus server interface.  Also
change user/group name to "_mandos".

* debian/mandos.postinst: Rename old "mandos" user and group to
                          "_mandos"; create "_mandos" user and group
                          if none exist.
* debian/mandos-client.postinst: - '' -

* initramfs-tools-hook: Try "_mandos" before "mandos" as user and
                        group name.

* mandos (_datetime_to_dbus_struct): New; was previously local.
  (Client.started): Renamed to "last_started".  All users changed.
  (Client.started): New; boolean.
  (Client.dbus_object_path): New.
  (Client.check_command): Renamed to "checker_command".  All users
                          changed.
  (Client.__init__): Set and use "self.dbus_object_path".  Set
                     "self.started".
  (Client.start): Update "self.started".  Emit "self.PropertyChanged"
                  signals for both "started" and "last_started".
  (Client.stop): Update "self.started".  Emit "self.PropertyChanged"
                 signal for "started".
  (Client.checker_callback): Take additional "command" argument.  All
                             callers changed. Emit
                             "self.PropertyChanged" signal.
  (Client.bump_timeout): Emit "self.PropertyChanged" signal for
                         "last_checked_ok".
  (Client.start_checker): Emit "self.PropertyChanged" signal for
                          "checker_running".
  (Client.stop_checker): Emit "self.PropertyChanged" signal for
                         "checker_running".
  (Client.still_valid): Bug fix: use "getattr(self, started, False)"
                        instead of "self.started" in case this client
                        object is so new that the "started" attribute
                        has not been created yet.
  (Client.IntervalChanged, Client.CheckerIsRunning, Client.GetChecker,
  Client.GetCreated, Client.GetFingerprint, Client.GetHost,
  Client.GetInterval, Client.GetName, Client.GetStarted,
  Client.GetTimeout, Client.StateChanged, Client.TimeoutChanged):
  Removed; all callers changed.
  (Client.CheckerCompleted): Add "condition" and "command" arguments.
                             All callers changed.
  (Client.GetAllProperties, Client.PropertyChanged): New.
  (Client.StillValid): Renamed to "IsStillValid".
  (Client.StartChecker): Changed to its own function to avoid the
                         return value from "Client.start_checker()".
  (Client.Stop): Changed to its own function to avoid the return value
                 from "Client.stop()".
  (main): Try "_mandos" before "mandos" as user and group name.
          Removed inner function "remove_from_clients".  New inner
          class "MandosServer".

Show diffs side-by-side

added added

removed removed

Lines of Context:
plugin-runner.c
2
2
/*
3
3
 * Mandos plugin runner - Run Mandos plugins
4
4
 *
5
 
 * Copyright © 2007-2008 Teddy Hogeborn & Björn Påhlsson
 
5
 * Copyright © 2008 Teddy Hogeborn
 
6
 * Copyright © 2008 Björn Påhlsson
6
7
 * 
7
8
 * This program is free software: you can redistribute it and/or
8
9
 * modify it under the terms of the GNU General Public License as
21
22
 * Contact the authors at <mandos@fukt.bsnet.se>.
22
23
 */
23
24
 
24
 
#define _GNU_SOURCE             /* TEMP_FAILURE_RETRY() */
25
 
 
 
25
#define _GNU_SOURCE             /* TEMP_FAILURE_RETRY(), getline(),
 
26
                                   asprintf() */
26
27
#include <stddef.h>             /* size_t, NULL */
27
28
#include <stdlib.h>             /* malloc(), exit(), EXIT_FAILURE,
28
29
                                   EXIT_SUCCESS, realloc() */
29
30
#include <stdbool.h>            /* bool, true, false */
30
 
#include <stdio.h>              /* perror, popen(), fileno(),
31
 
                                   fprintf(), stderr, STDOUT_FILENO */
 
31
#include <stdio.h>              /* perror, fileno(), fprintf(),
 
32
                                   stderr, STDOUT_FILENO */
32
33
#include <sys/types.h>          /* DIR, opendir(), stat(), struct
33
34
                                   stat, waitpid(), WIFEXITED(),
34
35
                                   WEXITSTATUS(), wait(), pid_t,
46
47
                                   fcntl(), setuid(), setgid(),
47
48
                                   F_GETFD, F_SETFD, FD_CLOEXEC,
48
49
                                   access(), pipe(), fork(), close()
49
 
                                   dup2, STDOUT_FILENO, _exit(),
 
50
                                   dup2(), STDOUT_FILENO, _exit(),
50
51
                                   execv(), write(), read(),
51
52
                                   close() */
52
53
#include <fcntl.h>              /* fcntl(), F_GETFD, F_SETFD,
53
54
                                   FD_CLOEXEC */
54
 
#include <string.h>             /* strtok, strlen(), strcpy(),
55
 
                                   strcat() */
 
55
#include <string.h>             /* strsep, strlen(), asprintf() */
56
56
#include <errno.h>              /* errno */
57
57
#include <argp.h>               /* struct argp_option, struct
58
58
                                   argp_state, struct argp,
59
59
                                   argp_parse(), ARGP_ERR_UNKNOWN,
60
 
                                   ARGP_KEY_END, ARGP_KEY_ARG, error_t */
 
60
                                   ARGP_KEY_END, ARGP_KEY_ARG,
 
61
                                   error_t */
61
62
#include <signal.h>             /* struct sigaction, sigemptyset(),
62
63
                                   sigaddset(), sigaction(),
63
64
                                   sigprocmask(), SIG_BLOCK, SIGCHLD,
66
67
 
67
68
#define BUFFER_SIZE 256
68
69
 
69
 
const char *argp_program_version = "mandos-client 1.0";
 
70
#define PDIR "/lib/mandos/plugins.d"
 
71
#define AFILE "/conf/conf.d/mandos/plugin-runner.conf"
 
72
 
 
73
const char *argp_program_version = "plugin-runner " VERSION;
70
74
const char *argp_program_bug_address = "<mandos@fukt.bsnet.se>";
71
75
 
72
 
struct process;
 
76
typedef struct plugin{
 
77
  char *name;                   /* can be NULL or any plugin name */
 
78
  char **argv;
 
79
  int argc;
 
80
  char **environ;
 
81
  int envc;
 
82
  bool disabled;
73
83
 
74
 
typedef struct process{
 
84
  /* Variables used for running processes*/
75
85
  pid_t pid;
76
86
  int fd;
77
87
  char *buffer;
78
88
  size_t buffer_size;
79
89
  size_t buffer_length;
80
90
  bool eof;
81
 
  bool completed;
82
 
  int status;
83
 
  struct process *next;
84
 
} process;
85
 
 
86
 
typedef struct plugin{
87
 
  char *name;                   /* can be NULL or any plugin name */
88
 
  char **argv;
89
 
  int argc;
90
 
  bool disabled;
 
91
  volatile bool completed;
 
92
  volatile int status;
91
93
  struct plugin *next;
92
94
} plugin;
93
95
 
94
 
static plugin *getplugin(char *name, plugin **plugin_list){
95
 
  for (plugin *p = *plugin_list; p != NULL; p = p->next){
 
96
static plugin *plugin_list = NULL;
 
97
 
 
98
/* Gets an existing plugin based on name,
 
99
   or if none is found, creates a new one */
 
100
static plugin *getplugin(char *name){
 
101
  /* Check for exiting plugin with that name */
 
102
  for (plugin *p = plugin_list; p != NULL; p = p->next){
96
103
    if ((p->name == name)
97
104
        or (p->name and name and (strcmp(p->name, name) == 0))){
98
105
      return p;
101
108
  /* Create a new plugin */
102
109
  plugin *new_plugin = malloc(sizeof(plugin));
103
110
  if (new_plugin == NULL){
104
 
    perror("malloc");
105
 
    exit(EXIT_FAILURE);
106
 
  }
107
 
  new_plugin->name = name;
 
111
    return NULL;
 
112
  }
 
113
  char *copy_name = NULL;
 
114
  if(name != NULL){
 
115
    copy_name = strdup(name);
 
116
    if(copy_name == NULL){
 
117
      return NULL;
 
118
    }
 
119
  }
 
120
  
 
121
  *new_plugin = (plugin) { .name = copy_name,
 
122
                           .argc = 1,
 
123
                           .disabled = false,
 
124
                           .next = plugin_list };
 
125
  
108
126
  new_plugin->argv = malloc(sizeof(char *) * 2);
109
127
  if (new_plugin->argv == NULL){
110
 
    perror("malloc");
111
 
    exit(EXIT_FAILURE);
 
128
    free(copy_name);
 
129
    free(new_plugin);
 
130
    return NULL;
112
131
  }
113
 
  new_plugin->argv[0] = name;
 
132
  new_plugin->argv[0] = copy_name;
114
133
  new_plugin->argv[1] = NULL;
115
 
  new_plugin->argc = 1;
116
 
  new_plugin->disabled = false;
117
 
  new_plugin->next = *plugin_list;
 
134
  
 
135
  new_plugin->environ = malloc(sizeof(char *));
 
136
  if(new_plugin->environ == NULL){
 
137
    free(copy_name);
 
138
    free(new_plugin->argv);
 
139
    free(new_plugin);
 
140
    return NULL;
 
141
  }
 
142
  new_plugin->environ[0] = NULL;
 
143
  
118
144
  /* Append the new plugin to the list */
119
 
  *plugin_list = new_plugin;
 
145
  plugin_list = new_plugin;
120
146
  return new_plugin;
121
147
}
122
148
 
123
 
static void addargument(plugin *p, char *arg){
124
 
  p->argv[p->argc] = arg;
125
 
  p->argv = realloc(p->argv, sizeof(char *) * (size_t)(p->argc + 2));
126
 
  if (p->argv == NULL){
127
 
    perror("malloc");
128
 
    exit(EXIT_FAILURE);
129
 
  }
130
 
  p->argc++;
131
 
  p->argv[p->argc] = NULL;
 
149
/* Helper function for add_argument and add_environment */
 
150
static bool add_to_char_array(const char *new, char ***array,
 
151
                              int *len){
 
152
  /* Resize the pointed-to array to hold one more pointer */
 
153
  *array = realloc(*array, sizeof(char *)
 
154
                   * (size_t) ((*len) + 2));
 
155
  /* Malloc check */
 
156
  if(*array == NULL){
 
157
    return false;
 
158
  }
 
159
  /* Make a copy of the new string */
 
160
  char *copy = strdup(new);
 
161
  if(copy == NULL){
 
162
    return false;
 
163
  }
 
164
  /* Insert the copy */
 
165
  (*array)[*len] = copy;
 
166
  (*len)++;
 
167
  /* Add a new terminating NULL pointer to the last element */
 
168
  (*array)[*len] = NULL;
 
169
  return true;
 
170
}
 
171
 
 
172
/* Add to a plugin's argument vector */
 
173
static bool add_argument(plugin *p, const char *arg){
 
174
  if(p == NULL){
 
175
    return false;
 
176
  }
 
177
  return add_to_char_array(arg, &(p->argv), &(p->argc));
 
178
}
 
179
 
 
180
/* Add to a plugin's environment */
 
181
static bool add_environment(plugin *p, const char *def, bool replace){
 
182
  if(p == NULL){
 
183
    return false;
 
184
  }
 
185
  /* namelen = length of name of environment variable */
 
186
  size_t namelen = (size_t)(strchrnul(def, '=') - def);
 
187
  /* Search for this environment variable */
 
188
  for(char **e = p->environ; *e != NULL; e++){
 
189
    if(strncmp(*e, def, namelen + 1) == 0){
 
190
      /* It already exists */
 
191
      if(replace){
 
192
        char *new = realloc(*e, strlen(def) + 1);
 
193
        if(new == NULL){
 
194
          return false;
 
195
        }
 
196
        *e = new;
 
197
        strcpy(*e, def);
 
198
      }
 
199
      return true;
 
200
    }
 
201
  }
 
202
  return add_to_char_array(def, &(p->environ), &(p->envc));
132
203
}
133
204
 
134
205
/*
136
207
 * Descriptor Flags".
137
208
 * *Note File Descriptor Flags:(libc)Descriptor Flags.
138
209
 */
139
 
static int set_cloexec_flag(int fd)
140
 
{
 
210
static int set_cloexec_flag(int fd){
141
211
  int ret = fcntl(fd, F_GETFD, 0);
142
212
  /* If reading the flags failed, return error indication now. */
143
213
  if(ret < 0){
147
217
  return fcntl(fd, F_SETFD, ret | FD_CLOEXEC);
148
218
}
149
219
 
150
 
process *process_list = NULL;
151
220
 
152
 
/* Mark a process as completed when it exits, and save its exit
 
221
/* Mark processes as completed when they exit, and save their exit
153
222
   status. */
154
 
void handle_sigchld(__attribute__((unused)) int sig){
155
 
  process *proc = process_list;
156
 
  int status;
157
 
  pid_t pid = wait(&status);
158
 
  if(pid == -1){
159
 
    perror("wait");
160
 
    return;
161
 
  }
162
 
  while(proc != NULL and proc->pid != pid){
163
 
    proc = proc->next;
164
 
  }
165
 
  if(proc == NULL){
166
 
    /* Process not found in process list */
167
 
    return;
168
 
  }
169
 
  proc->status = status;
170
 
  proc->completed = true;
 
223
static void handle_sigchld(__attribute__((unused)) int sig){
 
224
  while(true){
 
225
    plugin *proc = plugin_list;
 
226
    int status;
 
227
    pid_t pid = waitpid(-1, &status, WNOHANG);
 
228
    if(pid == 0){
 
229
      /* Only still running child processes */
 
230
      break;
 
231
    }
 
232
    if(pid == -1){
 
233
      if (errno != ECHILD){
 
234
        perror("waitpid");
 
235
      }
 
236
      /* No child processes */
 
237
      break;
 
238
    }
 
239
    
 
240
    /* A child exited, find it in process_list */
 
241
    while(proc != NULL and proc->pid != pid){
 
242
      proc = proc->next;
 
243
    }
 
244
    if(proc == NULL){
 
245
      /* Process not found in process list */
 
246
      continue;
 
247
    }
 
248
    proc->status = status;
 
249
    proc->completed = true;
 
250
  }
171
251
}
172
252
 
173
 
bool print_out_password(const char *buffer, size_t length){
 
253
/* Prints out a password to stdout */
 
254
static bool print_out_password(const char *buffer, size_t length){
174
255
  ssize_t ret;
175
 
  if(length>0 and buffer[length-1] == '\n'){
176
 
    length--;
177
 
  }
178
256
  for(size_t written = 0; written < length; written += (size_t)ret){
179
257
    ret = TEMP_FAILURE_RETRY(write(STDOUT_FILENO, buffer + written,
180
258
                                   length - written));
185
263
  return true;
186
264
}
187
265
 
 
266
/* Removes and free a plugin from the plugin list */
 
267
static void free_plugin(plugin *plugin_node){
 
268
  
 
269
  for(char **arg = plugin_node->argv; *arg != NULL; arg++){
 
270
    free(*arg);
 
271
  }
 
272
  free(plugin_node->argv);
 
273
  for(char **env = plugin_node->environ; *env != NULL; env++){
 
274
    free(*env);
 
275
  }
 
276
  free(plugin_node->environ);
 
277
  free(plugin_node->buffer);
 
278
 
 
279
  /* Removes the plugin from the singly-linked list */
 
280
  if(plugin_node == plugin_list){
 
281
    /* First one - simple */
 
282
    plugin_list = plugin_list->next;
 
283
  } else {
 
284
    /* Second one or later */
 
285
    for(plugin *p = plugin_list; p != NULL; p = p->next){
 
286
      if(p->next == plugin_node){
 
287
        p->next = plugin_node->next;
 
288
        break;
 
289
      }
 
290
    }
 
291
  }
 
292
  
 
293
  free(plugin_node);
 
294
}
 
295
 
 
296
static void free_plugin_list(void){
 
297
  while(plugin_list != NULL){
 
298
    free_plugin(plugin_list);
 
299
  }
 
300
}
 
301
 
188
302
int main(int argc, char *argv[]){
189
 
  const char *plugindir = "/conf/conf.d/mandos/plugins.d";
 
303
  char *plugindir = NULL;
 
304
  char *argfile = NULL;
 
305
  FILE *conffp;
190
306
  size_t d_name_len;
191
307
  DIR *dir = NULL;
192
308
  struct dirent *dirst;
200
316
  struct sigaction old_sigchld_action;
201
317
  struct sigaction sigchld_action = { .sa_handler = handle_sigchld,
202
318
                                      .sa_flags = SA_NOCLDSTOP };
203
 
  char *plus_options = NULL;
204
 
  char **plus_argv = NULL;
205
 
 
 
319
  char **custom_argv = NULL;
 
320
  int custom_argc = 0;
 
321
  
206
322
  /* Establish a signal handler */
207
323
  sigemptyset(&sigchld_action.sa_mask);
208
324
  ret = sigaddset(&sigchld_action.sa_mask, SIGCHLD);
209
 
  if(ret < 0){
 
325
  if(ret == -1){
210
326
    perror("sigaddset");
211
 
    exit(EXIT_FAILURE);
 
327
    exitstatus = EXIT_FAILURE;
 
328
    goto fallback;
212
329
  }
213
330
  ret = sigaction(SIGCHLD, &sigchld_action, &old_sigchld_action);
214
 
  if(ret < 0){
 
331
  if(ret == -1){
215
332
    perror("sigaction");
216
 
    exit(EXIT_FAILURE);
 
333
    exitstatus = EXIT_FAILURE;
 
334
    goto fallback;
217
335
  }
218
336
  
219
337
  /* The options we understand. */
221
339
    { .name = "global-options", .key = 'g',
222
340
      .arg = "OPTION[,OPTION[,...]]",
223
341
      .doc = "Options passed to all plugins" },
 
342
    { .name = "global-env", .key = 'G',
 
343
      .arg = "VAR=value",
 
344
      .doc = "Environment variable passed to all plugins" },
224
345
    { .name = "options-for", .key = 'o',
225
346
      .arg = "PLUGIN:OPTION[,OPTION[,...]]",
226
347
      .doc = "Options passed only to specified plugin" },
 
348
    { .name = "env-for", .key = 'E',
 
349
      .arg = "PLUGIN:ENV=value",
 
350
      .doc = "Environment variable passed to specified plugin" },
227
351
    { .name = "disable", .key = 'd',
228
352
      .arg = "PLUGIN",
229
353
      .doc = "Disable a specific plugin", .group = 1 },
 
354
    { .name = "enable", .key = 'e',
 
355
      .arg = "PLUGIN",
 
356
      .doc = "Enable a specific plugin", .group = 1 },
230
357
    { .name = "plugin-dir", .key = 128,
231
358
      .arg = "DIRECTORY",
232
359
      .doc = "Specify a different plugin directory", .group = 2 },
233
 
    { .name = "userid", .key = 129,
234
 
      .arg = "ID", .flags = 0,
235
 
      .doc = "User ID the plugins will run as", .group = 2 },
236
 
    { .name = "groupid", .key = 130,
237
 
      .arg = "ID", .flags = 0,
238
 
      .doc = "Group ID the plugins will run as", .group = 2 },
239
 
    { .name = "debug", .key = 131,
240
 
      .doc = "Debug mode", .group = 3 },
 
360
    { .name = "config-file", .key = 129,
 
361
      .arg = "FILE",
 
362
      .doc = "Specify a different configuration file", .group = 2 },
 
363
    { .name = "userid", .key = 130,
 
364
      .arg = "ID", .flags = 0,
 
365
      .doc = "User ID the plugins will run as", .group = 3 },
 
366
    { .name = "groupid", .key = 131,
 
367
      .arg = "ID", .flags = 0,
 
368
      .doc = "Group ID the plugins will run as", .group = 3 },
 
369
    { .name = "debug", .key = 132,
 
370
      .doc = "Debug mode", .group = 4 },
241
371
    { .name = NULL }
242
372
  };
243
373
  
244
 
  error_t parse_opt (int key, char *arg, struct argp_state *state) {
245
 
    /* Get the INPUT argument from `argp_parse', which we know is a
246
 
       pointer to our plugin list pointer. */
247
 
    plugin **plugins = state->input;
 
374
  error_t parse_opt (int key, char *arg, __attribute__((unused))
 
375
                     struct argp_state *state) {
248
376
    switch (key) {
249
 
    case 'g':
250
 
      if (arg != NULL){
251
 
        char *p = strtok(arg, ",");
252
 
        do{
253
 
          addargument(getplugin(NULL, plugins), p);
254
 
          p = strtok(NULL, ",");
255
 
        } while (p != NULL);
256
 
      }
257
 
      break;
258
 
    case 'o':
259
 
      if (arg != NULL){
260
 
        char *name = strtok(arg, ":");
261
 
        char *p = strtok(NULL, ":");
262
 
        if(p != NULL){
263
 
          p = strtok(p, ",");
264
 
          do{
265
 
            addargument(getplugin(name, plugins), p);
266
 
            p = strtok(NULL, ",");
267
 
          } while (p != NULL);
268
 
        }
269
 
      }
270
 
      break;
271
 
    case 'd':
272
 
      if (arg != NULL){
273
 
        getplugin(arg, plugins)->disabled = true;
274
 
      }
275
 
      break;
276
 
    case 128:
277
 
      plugindir = arg;
278
 
      break;
279
 
    case 129:
 
377
    case 'g':                   /* --global-options */
 
378
      if (arg != NULL){
 
379
        char *p;
 
380
        while((p = strsep(&arg, ",")) != NULL){
 
381
          if(p[0] == '\0'){
 
382
            continue;
 
383
          }
 
384
          if(not add_argument(getplugin(NULL), p)){
 
385
            perror("add_argument");
 
386
            return ARGP_ERR_UNKNOWN;
 
387
          }
 
388
        }
 
389
      }
 
390
      break;
 
391
    case 'G':                   /* --global-env */
 
392
      if(arg == NULL){
 
393
        break;
 
394
      }
 
395
      if(not add_environment(getplugin(NULL), arg, true)){
 
396
        perror("add_environment");
 
397
      }
 
398
      break;
 
399
    case 'o':                   /* --options-for */
 
400
      if (arg != NULL){
 
401
        char *p_name = strsep(&arg, ":");
 
402
        if(p_name[0] == '\0' or arg == NULL){
 
403
          break;
 
404
        }
 
405
        char *opt = strsep(&arg, ":");
 
406
        if(opt[0] == '\0' or opt == NULL){
 
407
          break;
 
408
        }
 
409
        char *p;
 
410
        while((p = strsep(&opt, ",")) != NULL){
 
411
          if(p[0] == '\0'){
 
412
            continue;
 
413
          }
 
414
          if(not add_argument(getplugin(p_name), p)){
 
415
            perror("add_argument");
 
416
            return ARGP_ERR_UNKNOWN;
 
417
          }
 
418
        }
 
419
      }
 
420
      break;
 
421
    case 'E':                   /* --env-for */
 
422
      if(arg == NULL){
 
423
        break;
 
424
      }
 
425
      {
 
426
        char *envdef = strchr(arg, ':');
 
427
        if(envdef == NULL){
 
428
          break;
 
429
        }
 
430
        *envdef = '\0';
 
431
        if(not add_environment(getplugin(arg), envdef+1, true)){
 
432
          perror("add_environment");
 
433
        }
 
434
      }
 
435
      break;
 
436
    case 'd':                   /* --disable */
 
437
      if (arg != NULL){
 
438
        plugin *p = getplugin(arg);
 
439
        if(p == NULL){
 
440
          return ARGP_ERR_UNKNOWN;
 
441
        }
 
442
        p->disabled = true;
 
443
      }
 
444
      break;
 
445
    case 'e':                   /* --enable */
 
446
      if (arg != NULL){
 
447
        plugin *p = getplugin(arg);
 
448
        if(p == NULL){
 
449
          return ARGP_ERR_UNKNOWN;
 
450
        }
 
451
        p->disabled = false;
 
452
      }
 
453
      break;
 
454
    case 128:                   /* --plugin-dir */
 
455
      free(plugindir);
 
456
      plugindir = strdup(arg);
 
457
      if(plugindir == NULL){
 
458
        perror("strdup");
 
459
      }      
 
460
      break;
 
461
    case 129:                   /* --config-file */
 
462
      /* This is already done by parse_opt_config_file() */
 
463
      break;
 
464
    case 130:                   /* --userid */
280
465
      uid = (uid_t)strtol(arg, NULL, 10);
281
466
      break;
282
 
    case 130:
 
467
    case 131:                   /* --groupid */
283
468
      gid = (gid_t)strtol(arg, NULL, 10);
284
469
      break;
285
 
    case 131:
 
470
    case 132:                   /* --debug */
286
471
      debug = true;
287
472
      break;
288
473
    case ARGP_KEY_ARG:
289
 
      if(plus_options != NULL or arg == NULL or arg[0] != '+'){
290
 
        argp_usage (state);
291
 
      }
292
 
      plus_options = arg;
293
 
      break;
294
 
    case ARGP_KEY_END:
295
 
      break;
296
 
    default:
297
 
      return ARGP_ERR_UNKNOWN;
298
 
    }
299
 
    return 0;
300
 
  }
301
 
  
302
 
  plugin *plugin_list = NULL;
303
 
  
304
 
  struct argp argp = { .options = options, .parser = parse_opt,
305
 
                       .args_doc = "[+PLUS_SEPARATED_OPTIONS]",
 
474
      /* Cryptsetup always passes an argument, which is an empty
 
475
         string if "none" was specified in /etc/crypttab.  So if
 
476
         argument was empty, we ignore it silently. */
 
477
      if(arg[0] != '\0'){
 
478
        fprintf(stderr, "Ignoring unknown argument \"%s\"\n", arg);
 
479
      }
 
480
      break;
 
481
    case ARGP_KEY_END:
 
482
      break;
 
483
    default:
 
484
      return ARGP_ERR_UNKNOWN;
 
485
    }
 
486
    return 0;
 
487
  }
 
488
  
 
489
  /* This option parser is the same as parse_opt() above, except it
 
490
     ignores everything but the --config-file option. */
 
491
  error_t parse_opt_config_file (int key, char *arg,
 
492
                                 __attribute__((unused))
 
493
                                 struct argp_state *state) {
 
494
    switch (key) {
 
495
    case 'g':                   /* --global-options */
 
496
    case 'G':                   /* --global-env */
 
497
    case 'o':                   /* --options-for */
 
498
    case 'E':                   /* --env-for */
 
499
    case 'd':                   /* --disable */
 
500
    case 'e':                   /* --enable */
 
501
    case 128:                   /* --plugin-dir */
 
502
      break;
 
503
    case 129:                   /* --config-file */
 
504
      free(argfile);
 
505
      argfile = strdup(arg);
 
506
      if(argfile == NULL){
 
507
        perror("strdup");
 
508
      }
 
509
      break;      
 
510
    case 130:                   /* --userid */
 
511
    case 131:                   /* --groupid */
 
512
    case 132:                   /* --debug */
 
513
    case ARGP_KEY_ARG:
 
514
    case ARGP_KEY_END:
 
515
      break;
 
516
    default:
 
517
      return ARGP_ERR_UNKNOWN;
 
518
    }
 
519
    return 0;
 
520
  }
 
521
  
 
522
  struct argp argp = { .options = options,
 
523
                       .parser = parse_opt_config_file,
 
524
                       .args_doc = "",
306
525
                       .doc = "Mandos plugin runner -- Run plugins" };
307
526
  
308
 
  ret = argp_parse (&argp, argc, argv, 0, 0, &plugin_list);
 
527
  /* Parse using the parse_opt_config_file in order to get the custom
 
528
     config file location, if any. */
 
529
  ret = argp_parse (&argp, argc, argv, ARGP_IN_ORDER, 0, NULL);
309
530
  if (ret == ARGP_ERR_UNKNOWN){
310
531
    fprintf(stderr, "Unknown error while parsing arguments\n");
311
532
    exitstatus = EXIT_FAILURE;
312
 
    goto end;
 
533
    goto fallback;
313
534
  }
314
535
  
315
 
  if(plus_options){
316
 
    /* This is a mangled argument in the form of
317
 
     "+--option+--other-option=parameter+--yet-another-option", etc */
318
 
    /* Make new argc and argv vars, and call argp_parse() again. */
319
 
    plus_options++;             /* skip the first '+' character */
320
 
    const char delims[] = "+";
321
 
    char *arg;
322
 
    int new_argc = 1;
323
 
    plus_argv = malloc(sizeof(char*) * 2);
324
 
    if(plus_argv == NULL){
 
536
  /* Reset to the normal argument parser */
 
537
  argp.parser = parse_opt;
 
538
  
 
539
  /* Open the configfile if available */
 
540
  if (argfile == NULL){
 
541
    conffp = fopen(AFILE, "r");
 
542
  } else {
 
543
    conffp = fopen(argfile, "r");
 
544
  }  
 
545
  if(conffp != NULL){
 
546
    char *org_line = NULL;
 
547
    char *p, *arg, *new_arg, *line;
 
548
    size_t size = 0;
 
549
    ssize_t sret;
 
550
    const char whitespace_delims[] = " \r\t\f\v\n";
 
551
    const char comment_delim[] = "#";
 
552
 
 
553
    custom_argc = 1;
 
554
    custom_argv = malloc(sizeof(char*) * 2);
 
555
    if(custom_argv == NULL){
325
556
      perror("malloc");
326
557
      exitstatus = EXIT_FAILURE;
327
 
      goto end;
328
 
    }
329
 
    plus_argv[0] = argv[0];
330
 
    plus_argv[1] = NULL;
331
 
    arg = strtok(plus_options, delims); /* Get first argument */
332
 
    while(arg != NULL){
333
 
      new_argc++;
334
 
      plus_argv = realloc(plus_argv, sizeof(char *)
335
 
                         * ((unsigned int) new_argc + 1));
336
 
      if(plus_argv == NULL){
337
 
        perror("realloc");
338
 
        exitstatus = EXIT_FAILURE;
339
 
        goto end;
340
 
      }
341
 
      plus_argv[new_argc-1] = arg;
342
 
      plus_argv[new_argc] = NULL;
343
 
      arg = strtok(NULL, delims); /* Get next argument */
344
 
    }
345
 
    ret = argp_parse (&argp, new_argc, plus_argv, 0, 0, &plugin_list);
 
558
      goto fallback;
 
559
    }
 
560
    custom_argv[0] = argv[0];
 
561
    custom_argv[1] = NULL;
 
562
 
 
563
    /* for each line in the config file, strip whitespace and ignore
 
564
       commented text */
 
565
    while(true){
 
566
      sret = getline(&org_line, &size, conffp);
 
567
      if(sret == -1){
 
568
        break;
 
569
      }
 
570
 
 
571
      line = org_line;
 
572
      arg = strsep(&line, comment_delim);
 
573
      while((p = strsep(&arg, whitespace_delims)) != NULL){
 
574
        if(p[0] == '\0'){
 
575
          continue;
 
576
        }
 
577
        new_arg = strdup(p);
 
578
        if(new_arg == NULL){
 
579
          perror("strdup");
 
580
          exitstatus = EXIT_FAILURE;
 
581
          free(org_line);
 
582
          goto fallback;
 
583
        }
 
584
        
 
585
        custom_argc += 1;
 
586
        custom_argv = realloc(custom_argv, sizeof(char *)
 
587
                              * ((unsigned int) custom_argc + 1));
 
588
        if(custom_argv == NULL){
 
589
          perror("realloc");
 
590
          exitstatus = EXIT_FAILURE;
 
591
          free(org_line);
 
592
          goto fallback;
 
593
        }
 
594
        custom_argv[custom_argc-1] = new_arg;
 
595
        custom_argv[custom_argc] = NULL;        
 
596
      }
 
597
    }
 
598
    free(org_line);
 
599
  } else {
 
600
    /* Check for harmful errors and go to fallback. Other errors might
 
601
       not affect opening plugins */
 
602
    if (errno == EMFILE or errno == ENFILE or errno == ENOMEM){
 
603
      perror("fopen");
 
604
      exitstatus = EXIT_FAILURE;
 
605
      goto fallback;
 
606
    }
 
607
  }
 
608
  /* If there was any arguments from configuration file,
 
609
     pass them to parser as command arguments */
 
610
  if(custom_argv != NULL){
 
611
    ret = argp_parse (&argp, custom_argc, custom_argv, ARGP_IN_ORDER,
 
612
                      0, NULL);
346
613
    if (ret == ARGP_ERR_UNKNOWN){
347
614
      fprintf(stderr, "Unknown error while parsing arguments\n");
348
615
      exitstatus = EXIT_FAILURE;
349
 
      goto end;
 
616
      goto fallback;
350
617
    }
351
618
  }
352
619
  
 
620
  /* Parse actual command line arguments, to let them override the
 
621
     config file */
 
622
  ret = argp_parse (&argp, argc, argv, ARGP_IN_ORDER, 0, NULL);
 
623
  if (ret == ARGP_ERR_UNKNOWN){
 
624
    fprintf(stderr, "Unknown error while parsing arguments\n");
 
625
    exitstatus = EXIT_FAILURE;
 
626
    goto fallback;
 
627
  }
 
628
  
353
629
  if(debug){
354
630
    for(plugin *p = plugin_list; p != NULL; p=p->next){
355
631
      fprintf(stderr, "Plugin: %s has %d arguments\n",
357
633
      for(char **a = p->argv; *a != NULL; a++){
358
634
        fprintf(stderr, "\tArg: %s\n", *a);
359
635
      }
 
636
      fprintf(stderr, "...and %u environment variables\n", p->envc);
 
637
      for(char **a = p->environ; *a != NULL; a++){
 
638
        fprintf(stderr, "\t%s\n", *a);
 
639
      }
360
640
    }
361
641
  }
362
642
  
 
643
  /* Strip permissions down to nobody */
363
644
  ret = setuid(uid);
364
645
  if (ret == -1){
365
646
    perror("setuid");
366
 
  }
367
 
  
 
647
  }  
368
648
  setgid(gid);
369
649
  if (ret == -1){
370
650
    perror("setgid");
371
651
  }
372
652
  
373
 
  dir = opendir(plugindir);
 
653
  if (plugindir == NULL){
 
654
    dir = opendir(PDIR);
 
655
  } else {
 
656
    dir = opendir(plugindir);
 
657
  }
 
658
  
374
659
  if(dir == NULL){
375
660
    perror("Could not open plugin dir");
376
661
    exitstatus = EXIT_FAILURE;
377
 
    goto end;
 
662
    goto fallback;
378
663
  }
379
664
  
380
665
  /* Set the FD_CLOEXEC flag on the directory, if possible */
385
670
      if(ret < 0){
386
671
        perror("set_cloexec_flag");
387
672
        exitstatus = EXIT_FAILURE;
388
 
        goto end;
 
673
        goto fallback;
389
674
      }
390
675
    }
391
676
  }
392
677
  
393
678
  FD_ZERO(&rfds_all);
394
679
  
 
680
  /* Read and execute any executable in the plugin directory*/
395
681
  while(true){
396
682
    dirst = readdir(dir);
397
683
    
398
 
    // All directory entries have been processed
 
684
    /* All directory entries have been processed */
399
685
    if(dirst == NULL){
400
686
      if (errno == EBADF){
401
687
        perror("readdir");
402
688
        exitstatus = EXIT_FAILURE;
403
 
        goto end;
 
689
        goto fallback;
404
690
      }
405
691
      break;
406
692
    }
407
693
    
408
694
    d_name_len = strlen(dirst->d_name);
409
695
    
410
 
    // Ignore dotfiles, backup files and other junk
 
696
    /* Ignore dotfiles, backup files and other junk */
411
697
    {
412
698
      bool bad_name = false;
413
699
      
415
701
      
416
702
      const char const *bad_suffixes[] = { "~", "#", ".dpkg-new",
417
703
                                           ".dpkg-old",
 
704
                                           ".dpkg-bak",
418
705
                                           ".dpkg-divert", NULL };
419
706
      for(const char **pre = bad_prefixes; *pre != NULL; pre++){
420
707
        size_t pre_len = strlen(*pre);
428
715
          break;
429
716
        }
430
717
      }
431
 
      
432
718
      if(bad_name){
433
719
        continue;
434
720
      }
435
 
      
436
721
      for(const char **suf = bad_suffixes; *suf != NULL; suf++){
437
722
        size_t suf_len = strlen(*suf);
438
723
        if((d_name_len >= suf_len)
451
736
        continue;
452
737
      }
453
738
    }
454
 
    
455
 
    char *filename = malloc(d_name_len + strlen(plugindir) + 2);
456
 
    if (filename == NULL){
457
 
      perror("malloc");
458
 
      exitstatus = EXIT_FAILURE;
459
 
      goto end;
460
 
    }
461
 
    strcpy(filename, plugindir); /* Spurious warning */
462
 
    strcat(filename, "/");      /* Spurious warning */
463
 
    strcat(filename, dirst->d_name); /* Spurious warning */
 
739
 
 
740
    char *filename;
 
741
    if(plugindir == NULL){
 
742
      ret = asprintf(&filename, PDIR "/%s", dirst->d_name);
 
743
    } else {
 
744
      ret = asprintf(&filename, "%s/%s", plugindir, dirst->d_name);
 
745
    }
 
746
    if(ret < 0){
 
747
      perror("asprintf");
 
748
      continue;
 
749
    }
464
750
    
465
751
    ret = stat(filename, &st);
466
752
    if (ret == -1){
467
753
      perror("stat");
468
 
      exitstatus = EXIT_FAILURE;
469
 
      goto end;
 
754
      free(filename);
 
755
      continue;
470
756
    }
471
 
    
 
757
 
 
758
    /* Ignore non-executable files */
472
759
    if (not S_ISREG(st.st_mode) or (access(filename, X_OK) != 0)){
473
760
      if(debug){
474
761
        fprintf(stderr, "Ignoring plugin dir entry \"%s\""
477
764
      free(filename);
478
765
      continue;
479
766
    }
480
 
    if(getplugin(dirst->d_name, &plugin_list)->disabled){
 
767
    
 
768
    plugin *p = getplugin(dirst->d_name);
 
769
    if(p == NULL){
 
770
      perror("getplugin");
 
771
      free(filename);
 
772
      continue;
 
773
    }
 
774
    if(p->disabled){
481
775
      if(debug){
482
776
        fprintf(stderr, "Ignoring disabled plugin \"%s\"\n",
483
777
                dirst->d_name);
485
779
      free(filename);
486
780
      continue;
487
781
    }
488
 
    plugin *p = getplugin(dirst->d_name, &plugin_list);
489
782
    {
490
783
      /* Add global arguments to argument list for this plugin */
491
 
      plugin *g = getplugin(NULL, &plugin_list);
492
 
      for(char **a = g->argv + 1; *a != NULL; a++){
493
 
        addargument(p, *a);
494
 
      }
495
 
    }
496
 
    int pipefd[2]; 
 
784
      plugin *g = getplugin(NULL);
 
785
      if(g != NULL){
 
786
        for(char **a = g->argv + 1; *a != NULL; a++){
 
787
          if(not add_argument(p, *a)){
 
788
            perror("add_argument");
 
789
          }
 
790
        }
 
791
        /* Add global environment variables */
 
792
        for(char **e = g->environ; *e != NULL; e++){
 
793
          if(not add_environment(p, *e, false)){
 
794
            perror("add_environment");
 
795
          }
 
796
        }
 
797
      }
 
798
    }
 
799
    /* If this plugin has any environment variables, we will call
 
800
       using execve and need to duplicate the environment from this
 
801
       process, too. */
 
802
    if(p->environ[0] != NULL){
 
803
      for(char **e = environ; *e != NULL; e++){
 
804
        if(not add_environment(p, *e, false)){
 
805
          perror("add_environment");
 
806
        }
 
807
      }
 
808
    }
 
809
    
 
810
    int pipefd[2];
497
811
    ret = pipe(pipefd);
498
812
    if (ret == -1){
499
813
      perror("pipe");
500
814
      exitstatus = EXIT_FAILURE;
501
 
      goto end;
 
815
      goto fallback;
502
816
    }
 
817
    /* Ask OS to automatic close the pipe on exec */
503
818
    ret = set_cloexec_flag(pipefd[0]);
504
819
    if(ret < 0){
505
820
      perror("set_cloexec_flag");
506
821
      exitstatus = EXIT_FAILURE;
507
 
      goto end;
 
822
      goto fallback;
508
823
    }
509
824
    ret = set_cloexec_flag(pipefd[1]);
510
825
    if(ret < 0){
511
826
      perror("set_cloexec_flag");
512
827
      exitstatus = EXIT_FAILURE;
513
 
      goto end;
 
828
      goto fallback;
514
829
    }
515
830
    /* Block SIGCHLD until process is safely in process list */
516
831
    ret = sigprocmask (SIG_BLOCK, &sigchld_action.sa_mask, NULL);
517
832
    if(ret < 0){
518
833
      perror("sigprocmask");
519
834
      exitstatus = EXIT_FAILURE;
520
 
      goto end;
 
835
      goto fallback;
521
836
    }
522
 
    // Starting a new process to be watched
 
837
    /* Starting a new process to be watched */
523
838
    pid_t pid = fork();
 
839
    if(pid == -1){
 
840
      perror("fork");
 
841
      exitstatus = EXIT_FAILURE;
 
842
      goto fallback;
 
843
    }
524
844
    if(pid == 0){
525
845
      /* this is the child process */
526
846
      ret = sigaction(SIGCHLD, &old_sigchld_action, NULL);
528
848
        perror("sigaction");
529
849
        _exit(EXIT_FAILURE);
530
850
      }
531
 
      ret = sigprocmask (SIG_UNBLOCK, &sigchld_action.sa_mask, NULL);
 
851
      ret = sigprocmask(SIG_UNBLOCK, &sigchld_action.sa_mask, NULL);
532
852
      if(ret < 0){
533
853
        perror("sigprocmask");
534
854
        _exit(EXIT_FAILURE);
535
855
      }
536
 
 
 
856
      
537
857
      ret = dup2(pipefd[1], STDOUT_FILENO); /* replace our stdout */
538
858
      if(ret == -1){
539
859
        perror("dup2");
545
865
           above and must now close it manually here. */
546
866
        closedir(dir);
547
867
      }
548
 
      if(execv(filename, p->argv) < 0){
549
 
        perror("execv");
550
 
        _exit(EXIT_FAILURE);
 
868
      if(p->environ[0] == NULL){
 
869
        if(execv(filename, p->argv) < 0){
 
870
          perror("execv");
 
871
          _exit(EXIT_FAILURE);
 
872
        }
 
873
      } else {
 
874
        if(execve(filename, p->argv, p->environ) < 0){
 
875
          perror("execve");
 
876
          _exit(EXIT_FAILURE);
 
877
        }
551
878
      }
552
879
      /* no return */
553
880
    }
554
 
    /* parent process */
 
881
    /* Parent process */
 
882
    close(pipefd[1]);           /* Close unused write end of pipe */
555
883
    free(filename);
556
 
    close(pipefd[1]);           /* close unused write end of pipe */
557
 
    process *new_process = malloc(sizeof(process));
558
 
    if (new_process == NULL){
559
 
      perror("malloc");
 
884
    plugin *new_plugin = getplugin(dirst->d_name);
 
885
    if (new_plugin == NULL){
 
886
      perror("getplugin");
560
887
      ret = sigprocmask (SIG_UNBLOCK, &sigchld_action.sa_mask, NULL);
561
888
      if(ret < 0){
562
 
        perror("sigprocmask");
 
889
        perror("sigprocmask");
563
890
      }
564
891
      exitstatus = EXIT_FAILURE;
565
 
      goto end;
 
892
      goto fallback;
566
893
    }
567
894
    
568
 
    *new_process = (struct process){ .pid = pid,
569
 
                                     .fd = pipefd[0],
570
 
                                     .next = process_list };
571
 
    // List handling
572
 
    process_list = new_process;
 
895
    new_plugin->pid = pid;
 
896
    new_plugin->fd = pipefd[0];
 
897
    
573
898
    /* Unblock SIGCHLD so signal handler can be run if this process
574
899
       has already completed */
575
900
    ret = sigprocmask (SIG_UNBLOCK, &sigchld_action.sa_mask, NULL);
576
901
    if(ret < 0){
577
902
      perror("sigprocmask");
578
903
      exitstatus = EXIT_FAILURE;
579
 
      goto end;
580
 
    }
581
 
    
582
 
    FD_SET(new_process->fd, &rfds_all);
583
 
    
584
 
    if (maxfd < new_process->fd){
585
 
      maxfd = new_process->fd;
586
 
    }
587
 
    
588
 
  }
589
 
  
590
 
  /* Free the plugin list */
591
 
  for(plugin *next; plugin_list != NULL; plugin_list = next){
592
 
    next = plugin_list->next;
593
 
    free(plugin_list->argv);
594
 
    free(plugin_list);
 
904
      goto fallback;
 
905
    }
 
906
    
 
907
    FD_SET(new_plugin->fd, &rfds_all);
 
908
    
 
909
    if (maxfd < new_plugin->fd){
 
910
      maxfd = new_plugin->fd;
 
911
    }
595
912
  }
596
913
  
597
914
  closedir(dir);
598
915
  dir = NULL;
599
 
    
600
 
  if (process_list == NULL){
601
 
    fprintf(stderr, "No plugin processes started. Incorrect plugin"
602
 
            " directory?\n");
603
 
    process_list = NULL;
 
916
  
 
917
  for(plugin *p = plugin_list; p != NULL; p = p->next){
 
918
    if(p->pid != 0){
 
919
      break;
 
920
    }
 
921
    if(p->next == NULL){
 
922
      fprintf(stderr, "No plugin processes started. Incorrect plugin"
 
923
              " directory?\n");
 
924
      free_plugin_list();
 
925
    }
604
926
  }
605
 
  while(process_list){
 
927
  
 
928
  /* Main loop while running plugins exist */
 
929
  while(plugin_list){
606
930
    fd_set rfds = rfds_all;
607
931
    int select_ret = select(maxfd+1, &rfds, NULL, NULL, NULL);
608
932
    if (select_ret == -1){
609
933
      perror("select");
610
934
      exitstatus = EXIT_FAILURE;
611
 
      goto end;
 
935
      goto fallback;
612
936
    }
613
937
    /* OK, now either a process completed, or something can be read
614
938
       from one of them */
615
 
    for(process *proc = process_list; proc ; proc = proc->next){
 
939
    for(plugin *proc = plugin_list; proc != NULL;){
616
940
      /* Is this process completely done? */
617
941
      if(proc->eof and proc->completed){
618
942
        /* Only accept the plugin output if it exited cleanly */
619
943
        if(not WIFEXITED(proc->status)
620
944
           or WEXITSTATUS(proc->status) != 0){
621
945
          /* Bad exit by plugin */
 
946
 
622
947
          if(debug){
623
948
            if(WIFEXITED(proc->status)){
624
949
              fprintf(stderr, "Plugin %u exited with status %d\n",
633
958
                      (unsigned int) (proc->pid));
634
959
            }
635
960
          }
 
961
          
636
962
          /* Remove the plugin */
637
963
          FD_CLR(proc->fd, &rfds_all);
 
964
 
638
965
          /* Block signal while modifying process_list */
639
 
          ret = sigprocmask (SIG_BLOCK, &sigchld_action.sa_mask, NULL);
 
966
          ret = sigprocmask(SIG_BLOCK, &sigchld_action.sa_mask, NULL);
640
967
          if(ret < 0){
641
968
            perror("sigprocmask");
642
969
            exitstatus = EXIT_FAILURE;
643
 
            goto end;
644
 
          }
645
 
          /* Delete this process entry from the list */
646
 
          if(process_list == proc){
647
 
            /* First one - simple */
648
 
            process_list = proc->next;
649
 
          } else {
650
 
            /* Second one or later */
651
 
            for(process *p = process_list; p != NULL; p = p->next){
652
 
              if(p->next == proc){
653
 
                p->next = proc->next;
654
 
                break;
655
 
              }
656
 
            }
657
 
          }
 
970
            goto fallback;
 
971
          }
 
972
          
 
973
          plugin *next_plugin = proc->next;
 
974
          free_plugin(proc);
 
975
          proc = next_plugin;
 
976
          
658
977
          /* We are done modifying process list, so unblock signal */
659
978
          ret = sigprocmask (SIG_UNBLOCK, &sigchld_action.sa_mask,
660
979
                             NULL);
661
980
          if(ret < 0){
662
981
            perror("sigprocmask");
663
 
          }
664
 
          free(proc->buffer);
665
 
          free(proc);
666
 
          /* We deleted this process from the list, so we can't go
667
 
             proc->next.  Therefore, start over from the beginning of
668
 
             the process list */
669
 
          break;
 
982
            exitstatus = EXIT_FAILURE;
 
983
            goto fallback;
 
984
          }
 
985
          
 
986
          if(plugin_list == NULL){
 
987
            break;
 
988
          }
 
989
          
 
990
          continue;
670
991
        }
 
992
        
671
993
        /* This process exited nicely, so print its buffer */
672
 
 
673
 
        bool bret = print_out_password(proc->buffer, proc->buffer_length);
 
994
        
 
995
        bool bret = print_out_password(proc->buffer,
 
996
                                       proc->buffer_length);
674
997
        if(not bret){
675
998
          perror("print_out_password");
676
999
          exitstatus = EXIT_FAILURE;
677
1000
        }
678
 
        goto end;
 
1001
        goto fallback;
679
1002
      }
 
1003
      
680
1004
      /* This process has not completed.  Does it have any output? */
681
1005
      if(proc->eof or not FD_ISSET(proc->fd, &rfds)){
682
1006
        /* This process had nothing to say at this time */
 
1007
        proc = proc->next;
683
1008
        continue;
684
1009
      }
685
1010
      /* Before reading, make the process' data buffer large enough */
689
1014
        if (proc->buffer == NULL){
690
1015
          perror("malloc");
691
1016
          exitstatus = EXIT_FAILURE;
692
 
          goto end;
 
1017
          goto fallback;
693
1018
        }
694
1019
        proc->buffer_size += BUFFER_SIZE;
695
1020
      }
698
1023
                 BUFFER_SIZE);
699
1024
      if(ret < 0){
700
1025
        /* Read error from this process; ignore the error */
 
1026
        proc = proc->next;
701
1027
        continue;
702
1028
      }
703
1029
      if(ret == 0){
710
1036
  }
711
1037
 
712
1038
 
713
 
 end:
 
1039
 fallback:
714
1040
  
715
 
  if(process_list == NULL or exitstatus != EXIT_SUCCESS){
716
 
    /* Fallback if all plugins failed or an error occured */
 
1041
  if(plugin_list == NULL or exitstatus != EXIT_SUCCESS){
 
1042
    /* Fallback if all plugins failed, none are found or an error
 
1043
       occured */
717
1044
    bool bret;
718
1045
    fprintf(stderr, "Going to fallback mode using getpass(3)\n");
719
1046
    char *passwordbuffer = getpass("Password: ");
720
 
    bret = print_out_password(passwordbuffer, strlen(passwordbuffer));
 
1047
    size_t len = strlen(passwordbuffer);
 
1048
    /* Strip trailing newline */
 
1049
    if(len > 0 and passwordbuffer[len-1] == '\n'){
 
1050
      passwordbuffer[len-1] = '\0'; /* not strictly necessary */
 
1051
      len--;
 
1052
    }
 
1053
    bret = print_out_password(passwordbuffer, len);
721
1054
    if(not bret){
722
1055
      perror("print_out_password");
723
1056
      exitstatus = EXIT_FAILURE;
724
 
      goto end;
725
1057
    }
726
1058
  }
727
1059
  
728
1060
  /* Restore old signal handler */
729
 
  sigaction(SIGCHLD, &old_sigchld_action, NULL);
730
 
  
731
 
  free(plus_argv);
732
 
  
733
 
  /* Free the plugin list */
734
 
  for(plugin *next; plugin_list != NULL; plugin_list = next){
735
 
    next = plugin_list->next;
736
 
    free(plugin_list->argv);
737
 
    free(plugin_list);
 
1061
  ret = sigaction(SIGCHLD, &old_sigchld_action, NULL);
 
1062
  if(ret == -1){
 
1063
    perror("sigaction");
 
1064
    exitstatus = EXIT_FAILURE;
 
1065
  }
 
1066
  
 
1067
  if(custom_argv != NULL){
 
1068
    for(char **arg = custom_argv+1; *arg != NULL; arg++){
 
1069
      free(*arg);
 
1070
    }
 
1071
    free(custom_argv);
738
1072
  }
739
1073
  
740
1074
  if(dir != NULL){
741
1075
    closedir(dir);
742
1076
  }
743
1077
  
744
 
  /* Free the process list and kill the processes */
745
 
  for(process *next; process_list != NULL; process_list = next){
746
 
    next = process_list->next;
747
 
    close(process_list->fd);
748
 
    ret = kill(process_list->pid, SIGTERM);
749
 
    if(ret == -1 and errno != ESRCH){
750
 
      /* set-uid proccesses migth not get closed */
751
 
      perror("kill");
 
1078
  /* Kill the processes */
 
1079
  for(plugin *p = plugin_list; p != NULL; p = p->next){
 
1080
    if(p->pid != 0){
 
1081
      close(p->fd);
 
1082
      ret = kill(p->pid, SIGTERM);
 
1083
      if(ret == -1 and errno != ESRCH){
 
1084
        /* Set-uid proccesses might not get closed */
 
1085
        perror("kill");
 
1086
      }
752
1087
    }
753
 
    free(process_list->buffer);
754
 
    free(process_list);
755
1088
  }
756
1089
  
757
1090
  /* Wait for any remaining child processes to terminate */
762
1095
    perror("wait");
763
1096
  }
764
1097
  
 
1098
  free_plugin_list();
 
1099
  
 
1100
  free(plugindir);
 
1101
  free(argfile);
 
1102
  
765
1103
  return exitstatus;
766
1104
}