/mandos/trunk

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

« back to all changes in this revision

Viewing changes to plugin-runner.c

  • Committer: Teddy Hogeborn
  • Date: 2016-06-03 17:27:03 UTC
  • Revision ID: teddy@recompile.se-20160603172703-mc6tjor6rhq4xy74
mandos: Bug fix: Do multiprocessing cleanup correctly on exit

* mandos (main): Save module "multiprocessing" and open file "wnull"
                 as scope variables accessible by function cleanup(),
                 since the module and global variable may not be
                 accessible when the cleanup() function is run as
                 scheduled by atexit().

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 © 2008,2009 Teddy Hogeborn
6
 
 * Copyright © 2008,2009 Björn Påhlsson
 
5
 * Copyright © 2008-2016 Teddy Hogeborn
 
6
 * Copyright © 2008-2016 Björn Påhlsson
7
7
 * 
8
8
 * This program is free software: you can redistribute it and/or
9
9
 * modify it under the terms of the GNU General Public License as
19
19
 * along with this program.  If not, see
20
20
 * <http://www.gnu.org/licenses/>.
21
21
 * 
22
 
 * Contact the authors at <mandos@fukt.bsnet.se>.
 
22
 * Contact the authors at <mandos@recompile.se>.
23
23
 */
24
24
 
25
25
#define _GNU_SOURCE             /* TEMP_FAILURE_RETRY(), getline(),
26
 
                                   asprintf() */
 
26
                                   O_CLOEXEC, pipe2() */
27
27
#include <stddef.h>             /* size_t, NULL */
28
 
#include <stdlib.h>             /* malloc(), exit(), EXIT_FAILURE,
29
 
                                   EXIT_SUCCESS, realloc() */
 
28
#include <stdlib.h>             /* malloc(), exit(), EXIT_SUCCESS,
 
29
                                   realloc() */
30
30
#include <stdbool.h>            /* bool, true, false */
31
 
#include <stdio.h>              /* perror, fileno(), fprintf(),
32
 
                                   stderr, STDOUT_FILENO */
33
 
#include <sys/types.h>          /* DIR, opendir(), stat(), struct
34
 
                                   stat, waitpid(), WIFEXITED(),
35
 
                                   WEXITSTATUS(), wait(), pid_t,
36
 
                                   uid_t, gid_t, getuid(), getgid(),
37
 
                                   dirfd() */
 
31
#include <stdio.h>              /* fileno(), fprintf(),
 
32
                                   stderr, STDOUT_FILENO, fclose() */
 
33
#include <sys/types.h>          /* fstat(), struct stat, waitpid(),
 
34
                                   WIFEXITED(), WEXITSTATUS(), wait(),
 
35
                                   pid_t, uid_t, gid_t, getuid(),
 
36
                                   getgid() */
38
37
#include <sys/select.h>         /* fd_set, select(), FD_ZERO(),
39
38
                                   FD_SET(), FD_ISSET(), FD_CLR */
40
39
#include <sys/wait.h>           /* wait(), waitpid(), WIFEXITED(),
41
 
                                   WEXITSTATUS(), WTERMSIG(),
42
 
                                   WCOREDUMP() */
43
 
#include <sys/stat.h>           /* struct stat, stat(), S_ISREG() */
 
40
                                   WEXITSTATUS(), WTERMSIG() */
 
41
#include <sys/stat.h>           /* struct stat, fstat(), S_ISREG() */
44
42
#include <iso646.h>             /* and, or, not */
45
 
#include <dirent.h>             /* DIR, struct dirent, opendir(),
46
 
                                   readdir(), closedir(), dirfd() */
47
 
#include <unistd.h>             /* struct stat, stat(), S_ISREG(),
48
 
                                   fcntl(), setuid(), setgid(),
49
 
                                   F_GETFD, F_SETFD, FD_CLOEXEC,
50
 
                                   access(), pipe(), fork(), close()
51
 
                                   dup2(), STDOUT_FILENO, _exit(),
52
 
                                   execv(), write(), read(),
53
 
                                   close() */
 
43
#include <dirent.h>             /* struct dirent, scandirat() */
 
44
#include <unistd.h>             /* fcntl(), F_GETFD, F_SETFD,
 
45
                                   FD_CLOEXEC, write(), STDOUT_FILENO,
 
46
                                   struct stat, fstat(), close(),
 
47
                                   setgid(), setuid(), S_ISREG(),
 
48
                                   faccessat() pipe2(), fork(),
 
49
                                   _exit(), dup2(), fexecve(), read()
 
50
                                */
54
51
#include <fcntl.h>              /* fcntl(), F_GETFD, F_SETFD,
55
 
                                   FD_CLOEXEC */
56
 
#include <string.h>             /* strsep, strlen(), asprintf(),
57
 
                                   strsignal() */
 
52
                                   FD_CLOEXEC, openat(), scandirat(),
 
53
                                   pipe2() */
 
54
#include <string.h>             /* strsep, strlen(), strsignal(),
 
55
                                   strcmp(), strncmp() */
58
56
#include <errno.h>              /* errno */
59
57
#include <argp.h>               /* struct argp_option, struct
60
58
                                   argp_state, struct argp,
68
66
                                */
69
67
#include <errno.h>              /* errno, EBADF */
70
68
#include <inttypes.h>           /* intmax_t, PRIdMAX, strtoimax() */
 
69
#include <sysexits.h>           /* EX_OSERR, EX_USAGE, EX_IOERR,
 
70
                                   EX_CONFIG, EX_UNAVAILABLE, EX_OK */
 
71
#include <errno.h>              /* errno */
 
72
#include <error.h>              /* error() */
 
73
#include <fnmatch.h>            /* fnmatch() */
71
74
 
72
75
#define BUFFER_SIZE 256
73
76
 
74
77
#define PDIR "/lib/mandos/plugins.d"
 
78
#define PHDIR "/lib/mandos/plugin-helpers"
75
79
#define AFILE "/conf/conf.d/mandos/plugin-runner.conf"
76
80
 
77
81
const char *argp_program_version = "plugin-runner " VERSION;
78
 
const char *argp_program_bug_address = "<mandos@fukt.bsnet.se>";
 
82
const char *argp_program_bug_address = "<mandos@recompile.se>";
79
83
 
80
84
typedef struct plugin{
81
85
  char *name;                   /* can be NULL or any plugin name */
101
105
 
102
106
/* Gets an existing plugin based on name,
103
107
   or if none is found, creates a new one */
 
108
__attribute__((warn_unused_result))
104
109
static plugin *getplugin(char *name){
105
 
  /* Check for exiting plugin with that name */
 
110
  /* Check for existing plugin with that name */
106
111
  for(plugin *p = plugin_list; p != NULL; p = p->next){
107
112
    if((p->name == name)
108
113
       or (p->name and name and (strcmp(p->name, name) == 0))){
123
128
      copy_name = strdup(name);
124
129
    } while(copy_name == NULL and errno == EINTR);
125
130
    if(copy_name == NULL){
 
131
      int e = errno;
126
132
      free(new_plugin);
 
133
      errno = e;
127
134
      return NULL;
128
135
    }
129
136
  }
137
144
    new_plugin->argv = malloc(sizeof(char *) * 2);
138
145
  } while(new_plugin->argv == NULL and errno == EINTR);
139
146
  if(new_plugin->argv == NULL){
 
147
    int e = errno;
140
148
    free(copy_name);
141
149
    free(new_plugin);
 
150
    errno = e;
142
151
    return NULL;
143
152
  }
144
153
  new_plugin->argv[0] = copy_name;
148
157
    new_plugin->environ = malloc(sizeof(char *));
149
158
  } while(new_plugin->environ == NULL and errno == EINTR);
150
159
  if(new_plugin->environ == NULL){
 
160
    int e = errno;
151
161
    free(copy_name);
152
162
    free(new_plugin->argv);
153
163
    free(new_plugin);
 
164
    errno = e;
154
165
    return NULL;
155
166
  }
156
167
  new_plugin->environ[0] = NULL;
161
172
}
162
173
 
163
174
/* Helper function for add_argument and add_environment */
 
175
__attribute__((nonnull, warn_unused_result))
164
176
static bool add_to_char_array(const char *new, char ***array,
165
177
                              int *len){
166
178
  /* Resize the pointed-to array to hold one more pointer */
 
179
  char **new_array = NULL;
167
180
  do {
168
 
    *array = realloc(*array, sizeof(char *)
169
 
                     * (size_t) ((*len) + 2));
170
 
  } while(*array == NULL and errno == EINTR);
 
181
    new_array = realloc(*array, sizeof(char *)
 
182
                        * (size_t) ((*len) + 2));
 
183
  } while(new_array == NULL and errno == EINTR);
171
184
  /* Malloc check */
172
 
  if(*array == NULL){
 
185
  if(new_array == NULL){
173
186
    return false;
174
187
  }
 
188
  *array = new_array;
175
189
  /* Make a copy of the new string */
176
190
  char *copy;
177
191
  do {
189
203
}
190
204
 
191
205
/* Add to a plugin's argument vector */
 
206
__attribute__((nonnull(2), warn_unused_result))
192
207
static bool add_argument(plugin *p, const char *arg){
193
208
  if(p == NULL){
194
209
    return false;
197
212
}
198
213
 
199
214
/* Add to a plugin's environment */
 
215
__attribute__((nonnull(2), warn_unused_result))
200
216
static bool add_environment(plugin *p, const char *def, bool replace){
201
217
  if(p == NULL){
202
218
    return false;
204
220
  /* namelen = length of name of environment variable */
205
221
  size_t namelen = (size_t)(strchrnul(def, '=') - def);
206
222
  /* Search for this environment variable */
207
 
  for(char **e = p->environ; *e != NULL; e++){
208
 
    if(strncmp(*e, def, namelen + 1) == 0){
 
223
  for(char **envdef = p->environ; *envdef != NULL; envdef++){
 
224
    if(strncmp(*envdef, def, namelen + 1) == 0){
209
225
      /* It already exists */
210
226
      if(replace){
211
 
        char *new;
 
227
        char *new_envdef;
212
228
        do {
213
 
          new = realloc(*e, strlen(def) + 1);
214
 
        } while(new == NULL and errno == EINTR);
215
 
        if(new == NULL){
 
229
          new_envdef = realloc(*envdef, strlen(def) + 1);
 
230
        } while(new_envdef == NULL and errno == EINTR);
 
231
        if(new_envdef == NULL){
216
232
          return false;
217
233
        }
218
 
        *e = new;
219
 
        strcpy(*e, def);
 
234
        *envdef = new_envdef;
 
235
        strcpy(*envdef, def);
220
236
      }
221
237
      return true;
222
238
    }
224
240
  return add_to_char_array(def, &(p->environ), &(p->envc));
225
241
}
226
242
 
 
243
#ifndef O_CLOEXEC
227
244
/*
228
245
 * Based on the example in the GNU LibC manual chapter 13.13 "File
229
246
 * Descriptor Flags".
230
247
 | [[info:libc:Descriptor%20Flags][File Descriptor Flags]] |
231
248
 */
 
249
__attribute__((warn_unused_result))
232
250
static int set_cloexec_flag(int fd){
233
251
  int ret = (int)TEMP_FAILURE_RETRY(fcntl(fd, F_GETFD, 0));
234
252
  /* If reading the flags failed, return error indication now. */
239
257
  return (int)TEMP_FAILURE_RETRY(fcntl(fd, F_SETFD,
240
258
                                       ret | FD_CLOEXEC));
241
259
}
 
260
#endif  /* not O_CLOEXEC */
242
261
 
243
262
 
244
263
/* Mark processes as completed when they exit, and save their exit
258
277
        /* No child processes */
259
278
        break;
260
279
      }
261
 
      perror("waitpid");
 
280
      error(0, errno, "waitpid");
262
281
    }
263
282
    
264
283
    /* A child exited, find it in process_list */
276
295
}
277
296
 
278
297
/* Prints out a password to stdout */
 
298
__attribute__((nonnull, warn_unused_result))
279
299
static bool print_out_password(const char *buffer, size_t length){
280
300
  ssize_t ret;
281
301
  for(size_t written = 0; written < length; written += (size_t)ret){
289
309
}
290
310
 
291
311
/* Removes and free a plugin from the plugin list */
 
312
__attribute__((nonnull))
292
313
static void free_plugin(plugin *plugin_node){
293
314
  
294
315
  for(char **arg = plugin_node->argv; *arg != NULL; arg++){
326
347
 
327
348
int main(int argc, char *argv[]){
328
349
  char *plugindir = NULL;
 
350
  char *pluginhelperdir = NULL;
329
351
  char *argfile = NULL;
330
352
  FILE *conffp;
331
 
  size_t d_name_len;
332
 
  DIR *dir = NULL;
333
 
  struct dirent *dirst;
 
353
  struct dirent **direntries = NULL;
334
354
  struct stat st;
335
355
  fd_set rfds_all;
336
356
  int ret, maxfd = 0;
344
364
                                      .sa_flags = SA_NOCLDSTOP };
345
365
  char **custom_argv = NULL;
346
366
  int custom_argc = 0;
 
367
  int dir_fd = -1;
347
368
  
348
369
  /* Establish a signal handler */
349
370
  sigemptyset(&sigchld_action.sa_mask);
350
371
  ret = sigaddset(&sigchld_action.sa_mask, SIGCHLD);
351
372
  if(ret == -1){
352
 
    perror("sigaddset");
353
 
    exitstatus = EXIT_FAILURE;
 
373
    error(0, errno, "sigaddset");
 
374
    exitstatus = EX_OSERR;
354
375
    goto fallback;
355
376
  }
356
377
  ret = sigaction(SIGCHLD, &sigchld_action, &old_sigchld_action);
357
378
  if(ret == -1){
358
 
    perror("sigaction");
359
 
    exitstatus = EXIT_FAILURE;
 
379
    error(0, errno, "sigaction");
 
380
    exitstatus = EX_OSERR;
360
381
    goto fallback;
361
382
  }
362
383
  
394
415
      .doc = "Group ID the plugins will run as", .group = 3 },
395
416
    { .name = "debug", .key = 132,
396
417
      .doc = "Debug mode", .group = 4 },
 
418
    { .name = "plugin-helper-dir", .key = 133,
 
419
      .arg = "DIRECTORY",
 
420
      .doc = "Specify a different plugin helper directory",
 
421
      .group = 2 },
 
422
    /*
 
423
     * These reproduce what we would get without ARGP_NO_HELP
 
424
     */
 
425
    { .name = "help", .key = '?',
 
426
      .doc = "Give this help list", .group = -1 },
 
427
    { .name = "usage", .key = -3,
 
428
      .doc = "Give a short usage message", .group = -1 },
 
429
    { .name = "version", .key = 'V',
 
430
      .doc = "Print program version", .group = -1 },
397
431
    { .name = NULL }
398
432
  };
399
433
  
400
 
  error_t parse_opt(int key, char *arg, __attribute__((unused))
401
 
                    struct argp_state *state){
 
434
  __attribute__((nonnull(3)))
 
435
  error_t parse_opt(int key, char *arg, struct argp_state *state){
 
436
    errno = 0;
402
437
    switch(key){
403
438
      char *tmp;
404
 
      intmax_t tmpmax;
 
439
      intmax_t tmp_id;
405
440
    case 'g':                   /* --global-options */
406
 
      if(arg != NULL){
 
441
      {
407
442
        char *plugin_option;
408
443
        while((plugin_option = strsep(&arg, ",")) != NULL){
409
 
          if(plugin_option[0] == '\0'){
410
 
            continue;
411
 
          }
412
444
          if(not add_argument(getplugin(NULL), plugin_option)){
413
 
            perror("add_argument");
414
 
            return ARGP_ERR_UNKNOWN;
 
445
            break;
415
446
          }
416
447
        }
 
448
        errno = 0;
417
449
      }
418
450
      break;
419
451
    case 'G':                   /* --global-env */
420
 
      if(arg == NULL){
421
 
        break;
422
 
      }
423
 
      if(not add_environment(getplugin(NULL), arg, true)){
424
 
        perror("add_environment");
 
452
      if(add_environment(getplugin(NULL), arg, true)){
 
453
        errno = 0;
425
454
      }
426
455
      break;
427
456
    case 'o':                   /* --options-for */
428
 
      if(arg != NULL){
429
 
        char *plugin_name = strsep(&arg, ":");
430
 
        if(plugin_name[0] == '\0'){
431
 
          break;
432
 
        }
433
 
        char *plugin_option;
434
 
        while((plugin_option = strsep(&arg, ",")) != NULL){
435
 
          if(not add_argument(getplugin(plugin_name), plugin_option)){
436
 
            perror("add_argument");
437
 
            return ARGP_ERR_UNKNOWN;
 
457
      {
 
458
        char *option_list = strchr(arg, ':');
 
459
        if(option_list == NULL){
 
460
          argp_error(state, "No colon in \"%s\"", arg);
 
461
          errno = EINVAL;
 
462
          break;
 
463
        }
 
464
        *option_list = '\0';
 
465
        option_list++;
 
466
        if(arg[0] == '\0'){
 
467
          argp_error(state, "Empty plugin name");
 
468
          errno = EINVAL;
 
469
          break;
 
470
        }
 
471
        char *option;
 
472
        while((option = strsep(&option_list, ",")) != NULL){
 
473
          if(not add_argument(getplugin(arg), option)){
 
474
            break;
438
475
          }
439
476
        }
 
477
        errno = 0;
440
478
      }
441
479
      break;
442
480
    case 'E':                   /* --env-for */
443
 
      if(arg == NULL){
444
 
        break;
445
 
      }
446
481
      {
447
482
        char *envdef = strchr(arg, ':');
448
483
        if(envdef == NULL){
 
484
          argp_error(state, "No colon in \"%s\"", arg);
 
485
          errno = EINVAL;
449
486
          break;
450
487
        }
451
488
        *envdef = '\0';
452
 
        if(not add_environment(getplugin(arg), envdef+1, true)){
453
 
          perror("add_environment");
 
489
        envdef++;
 
490
        if(arg[0] == '\0'){
 
491
          argp_error(state, "Empty plugin name");
 
492
          errno = EINVAL;
 
493
          break;
 
494
        }
 
495
        if(add_environment(getplugin(arg), envdef, true)){
 
496
          errno = 0;
454
497
        }
455
498
      }
456
499
      break;
457
500
    case 'd':                   /* --disable */
458
 
      if(arg != NULL){
 
501
      {
459
502
        plugin *p = getplugin(arg);
460
 
        if(p == NULL){
461
 
          return ARGP_ERR_UNKNOWN;
 
503
        if(p != NULL){
 
504
          p->disabled = true;
 
505
          errno = 0;
462
506
        }
463
 
        p->disabled = true;
464
507
      }
465
508
      break;
466
509
    case 'e':                   /* --enable */
467
 
      if(arg != NULL){
 
510
      {
468
511
        plugin *p = getplugin(arg);
469
 
        if(p == NULL){
470
 
          return ARGP_ERR_UNKNOWN;
 
512
        if(p != NULL){
 
513
          p->disabled = false;
 
514
          errno = 0;
471
515
        }
472
 
        p->disabled = false;
473
516
      }
474
517
      break;
475
518
    case 128:                   /* --plugin-dir */
476
519
      free(plugindir);
477
520
      plugindir = strdup(arg);
478
 
      if(plugindir == NULL){
479
 
        perror("strdup");
 
521
      if(plugindir != NULL){
 
522
        errno = 0;
480
523
      }
481
524
      break;
482
525
    case 129:                   /* --config-file */
483
526
      /* This is already done by parse_opt_config_file() */
484
527
      break;
485
528
    case 130:                   /* --userid */
486
 
      errno = 0;
487
 
      tmpmax = strtoimax(arg, &tmp, 10);
 
529
      tmp_id = strtoimax(arg, &tmp, 10);
488
530
      if(errno != 0 or tmp == arg or *tmp != '\0'
489
 
         or tmpmax != (uid_t)tmpmax){
490
 
        fprintf(stderr, "Bad user ID number: \"%s\", using %"
491
 
                PRIdMAX "\n", arg, (intmax_t)uid);
492
 
      } else {
493
 
        uid = (uid_t)tmpmax;
 
531
         or tmp_id != (uid_t)tmp_id){
 
532
        argp_error(state, "Bad user ID number: \"%s\", using %"
 
533
                   PRIdMAX, arg, (intmax_t)uid);
 
534
        break;
494
535
      }
 
536
      uid = (uid_t)tmp_id;
 
537
      errno = 0;
495
538
      break;
496
539
    case 131:                   /* --groupid */
497
 
      errno = 0;
498
 
      tmpmax = strtoimax(arg, &tmp, 10);
 
540
      tmp_id = strtoimax(arg, &tmp, 10);
499
541
      if(errno != 0 or tmp == arg or *tmp != '\0'
500
 
         or tmpmax != (gid_t)tmpmax){
501
 
        fprintf(stderr, "Bad group ID number: \"%s\", using %"
502
 
                PRIdMAX "\n", arg, (intmax_t)gid);
503
 
      } else {
504
 
        gid = (gid_t)tmpmax;
 
542
         or tmp_id != (gid_t)tmp_id){
 
543
        argp_error(state, "Bad group ID number: \"%s\", using %"
 
544
                   PRIdMAX, arg, (intmax_t)gid);
 
545
        break;
505
546
      }
 
547
      gid = (gid_t)tmp_id;
 
548
      errno = 0;
506
549
      break;
507
550
    case 132:                   /* --debug */
508
551
      debug = true;
509
552
      break;
 
553
    case 133:                   /* --plugin-helper-dir */
 
554
      free(pluginhelperdir);
 
555
      pluginhelperdir = strdup(arg);
 
556
      if(pluginhelperdir != NULL){
 
557
        errno = 0;
 
558
      }
 
559
      break;
 
560
      /*
 
561
       * These reproduce what we would get without ARGP_NO_HELP
 
562
       */
 
563
    case '?':                   /* --help */
 
564
      state->flags &= ~(unsigned int)ARGP_NO_EXIT; /* force exit */
 
565
      argp_state_help(state, state->out_stream, ARGP_HELP_STD_HELP);
 
566
    case -3:                    /* --usage */
 
567
      state->flags &= ~(unsigned int)ARGP_NO_EXIT; /* force exit */
 
568
      argp_state_help(state, state->out_stream,
 
569
                      ARGP_HELP_USAGE | ARGP_HELP_EXIT_OK);
 
570
    case 'V':                   /* --version */
 
571
      fprintf(state->out_stream, "%s\n", argp_program_version);
 
572
      exit(EXIT_SUCCESS);
 
573
      break;
510
574
/*
511
575
 * When adding more options before this line, remember to also add a
512
576
 * "case" to the "parse_opt_config_file" function below.
515
579
      /* Cryptsetup always passes an argument, which is an empty
516
580
         string if "none" was specified in /etc/crypttab.  So if
517
581
         argument was empty, we ignore it silently. */
518
 
      if(arg[0] != '\0'){
519
 
        fprintf(stderr, "Ignoring unknown argument \"%s\"\n", arg);
 
582
      if(arg[0] == '\0'){
 
583
        break;
520
584
      }
521
 
      break;
522
 
    case ARGP_KEY_END:
523
 
      break;
524
585
    default:
525
586
      return ARGP_ERR_UNKNOWN;
526
587
    }
527
 
    return 0;
 
588
    return errno;               /* Set to 0 at start */
528
589
  }
529
590
  
530
591
  /* This option parser is the same as parse_opt() above, except it
532
593
  error_t parse_opt_config_file(int key, char *arg,
533
594
                                __attribute__((unused))
534
595
                                struct argp_state *state){
 
596
    errno = 0;
535
597
    switch(key){
536
598
    case 'g':                   /* --global-options */
537
599
    case 'G':                   /* --global-env */
544
606
    case 129:                   /* --config-file */
545
607
      free(argfile);
546
608
      argfile = strdup(arg);
547
 
      if(argfile == NULL){
548
 
        perror("strdup");
 
609
      if(argfile != NULL){
 
610
        errno = 0;
549
611
      }
550
612
      break;
551
613
    case 130:                   /* --userid */
552
614
    case 131:                   /* --groupid */
553
615
    case 132:                   /* --debug */
 
616
    case 133:                   /* --plugin-helper-dir */
 
617
    case '?':                   /* --help */
 
618
    case -3:                    /* --usage */
 
619
    case 'V':                   /* --version */
554
620
    case ARGP_KEY_ARG:
555
 
    case ARGP_KEY_END:
556
621
      break;
557
622
    default:
558
623
      return ARGP_ERR_UNKNOWN;
559
624
    }
560
 
    return 0;
 
625
    return errno;
561
626
  }
562
627
  
563
628
  struct argp argp = { .options = options,
567
632
  
568
633
  /* Parse using parse_opt_config_file() in order to get the custom
569
634
     config file location, if any. */
570
 
  ret = argp_parse(&argp, argc, argv, ARGP_IN_ORDER, 0, NULL);
571
 
  if(ret == ARGP_ERR_UNKNOWN){
572
 
    fprintf(stderr, "Unknown error while parsing arguments\n");
573
 
    exitstatus = EXIT_FAILURE;
 
635
  ret = argp_parse(&argp, argc, argv,
 
636
                   ARGP_IN_ORDER | ARGP_NO_EXIT | ARGP_NO_HELP,
 
637
                   NULL, NULL);
 
638
  switch(ret){
 
639
  case 0:
 
640
    break;
 
641
  case ENOMEM:
 
642
  default:
 
643
    errno = ret;
 
644
    error(0, errno, "argp_parse");
 
645
    exitstatus = EX_OSERR;
 
646
    goto fallback;
 
647
  case EINVAL:
 
648
    exitstatus = EX_USAGE;
574
649
    goto fallback;
575
650
  }
576
651
  
593
668
    custom_argc = 1;
594
669
    custom_argv = malloc(sizeof(char*) * 2);
595
670
    if(custom_argv == NULL){
596
 
      perror("malloc");
597
 
      exitstatus = EXIT_FAILURE;
 
671
      error(0, errno, "malloc");
 
672
      exitstatus = EX_OSERR;
598
673
      goto fallback;
599
674
    }
600
675
    custom_argv[0] = argv[0];
616
691
        }
617
692
        new_arg = strdup(p);
618
693
        if(new_arg == NULL){
619
 
          perror("strdup");
620
 
          exitstatus = EXIT_FAILURE;
 
694
          error(0, errno, "strdup");
 
695
          exitstatus = EX_OSERR;
621
696
          free(org_line);
622
697
          goto fallback;
623
698
        }
624
699
        
625
700
        custom_argc += 1;
626
 
        custom_argv = realloc(custom_argv, sizeof(char *)
627
 
                              * ((unsigned int) custom_argc + 1));
628
 
        if(custom_argv == NULL){
629
 
          perror("realloc");
630
 
          exitstatus = EXIT_FAILURE;
631
 
          free(org_line);
632
 
          goto fallback;
 
701
        {
 
702
          char **new_argv = realloc(custom_argv, sizeof(char *)
 
703
                                    * ((size_t)custom_argc + 1));
 
704
          if(new_argv == NULL){
 
705
            error(0, errno, "realloc");
 
706
            exitstatus = EX_OSERR;
 
707
            free(new_arg);
 
708
            free(org_line);
 
709
            goto fallback;
 
710
          } else {
 
711
            custom_argv = new_argv;
 
712
          }
633
713
        }
634
714
        custom_argv[custom_argc-1] = new_arg;
635
715
        custom_argv[custom_argc] = NULL;
639
719
      ret = fclose(conffp);
640
720
    } while(ret == EOF and errno == EINTR);
641
721
    if(ret == EOF){
642
 
      perror("fclose");
643
 
      exitstatus = EXIT_FAILURE;
 
722
      error(0, errno, "fclose");
 
723
      exitstatus = EX_IOERR;
644
724
      goto fallback;
645
725
    }
646
726
    free(org_line);
648
728
    /* Check for harmful errors and go to fallback. Other errors might
649
729
       not affect opening plugins */
650
730
    if(errno == EMFILE or errno == ENFILE or errno == ENOMEM){
651
 
      perror("fopen");
652
 
      exitstatus = EXIT_FAILURE;
 
731
      error(0, errno, "fopen");
 
732
      exitstatus = EX_OSERR;
653
733
      goto fallback;
654
734
    }
655
735
  }
656
 
  /* If there was any arguments from configuration file,
657
 
     pass them to parser as command arguments */
 
736
  /* If there were any arguments from the configuration file, pass
 
737
     them to parser as command line arguments */
658
738
  if(custom_argv != NULL){
659
 
    ret = argp_parse(&argp, custom_argc, custom_argv, ARGP_IN_ORDER,
660
 
                     0, NULL);
661
 
    if(ret == ARGP_ERR_UNKNOWN){
662
 
      fprintf(stderr, "Unknown error while parsing arguments\n");
663
 
      exitstatus = EXIT_FAILURE;
 
739
    ret = argp_parse(&argp, custom_argc, custom_argv,
 
740
                     ARGP_IN_ORDER | ARGP_NO_EXIT | ARGP_NO_HELP,
 
741
                     NULL, NULL);
 
742
    switch(ret){
 
743
    case 0:
 
744
      break;
 
745
    case ENOMEM:
 
746
    default:
 
747
      errno = ret;
 
748
      error(0, errno, "argp_parse");
 
749
      exitstatus = EX_OSERR;
 
750
      goto fallback;
 
751
    case EINVAL:
 
752
      exitstatus = EX_CONFIG;
664
753
      goto fallback;
665
754
    }
666
755
  }
667
756
  
668
757
  /* Parse actual command line arguments, to let them override the
669
758
     config file */
670
 
  ret = argp_parse(&argp, argc, argv, ARGP_IN_ORDER, 0, NULL);
671
 
  if(ret == ARGP_ERR_UNKNOWN){
672
 
    fprintf(stderr, "Unknown error while parsing arguments\n");
673
 
    exitstatus = EXIT_FAILURE;
674
 
    goto fallback;
 
759
  ret = argp_parse(&argp, argc, argv,
 
760
                   ARGP_IN_ORDER | ARGP_NO_EXIT | ARGP_NO_HELP,
 
761
                   NULL, NULL);
 
762
  switch(ret){
 
763
  case 0:
 
764
    break;
 
765
  case ENOMEM:
 
766
  default:
 
767
    errno = ret;
 
768
    error(0, errno, "argp_parse");
 
769
    exitstatus = EX_OSERR;
 
770
    goto fallback;
 
771
  case EINVAL:
 
772
    exitstatus = EX_USAGE;
 
773
    goto fallback;
 
774
  }
 
775
  
 
776
  {
 
777
    char *pluginhelperenv;
 
778
    bool bret = true;
 
779
    ret = asprintf(&pluginhelperenv, "MANDOSPLUGINHELPERDIR=%s",
 
780
                   pluginhelperdir != NULL ? pluginhelperdir : PHDIR);
 
781
    if(ret != -1){
 
782
      bret = add_environment(getplugin(NULL), pluginhelperenv, true);
 
783
    }
 
784
    if(ret == -1 or not bret){
 
785
      error(0, errno, "Failed to set MANDOSPLUGINHELPERDIR"
 
786
            " environment variable to \"%s\" for all plugins\n",
 
787
            pluginhelperdir != NULL ? pluginhelperdir : PHDIR);
 
788
    }
 
789
    if(ret != -1){
 
790
      free(pluginhelperenv);
 
791
    }
675
792
  }
676
793
  
677
794
  if(debug){
688
805
    }
689
806
  }
690
807
  
691
 
  /* Strip permissions down to nobody */
692
 
  setgid(gid);
 
808
  if(getuid() == 0){
 
809
    /* Work around Debian bug #633582:
 
810
       <http://bugs.debian.org/633582> */
 
811
    int plugindir_fd = open(/* plugindir or */ PDIR, O_RDONLY);
 
812
    if(plugindir_fd == -1){
 
813
      if(errno != ENOENT){
 
814
        error(0, errno, "open(\"" PDIR "\")");
 
815
      }
 
816
    } else {
 
817
      ret = (int)TEMP_FAILURE_RETRY(fstat(plugindir_fd, &st));
 
818
      if(ret == -1){
 
819
        error(0, errno, "fstat");
 
820
      } else {
 
821
        if(S_ISDIR(st.st_mode) and st.st_uid == 0 and st.st_gid == 0){
 
822
          ret = fchown(plugindir_fd, uid, gid);
 
823
          if(ret == -1){
 
824
            error(0, errno, "fchown");
 
825
          }
 
826
        }
 
827
      }
 
828
      close(plugindir_fd);
 
829
    }
 
830
  }
 
831
  
 
832
  /* Lower permissions */
 
833
  ret = setgid(gid);
693
834
  if(ret == -1){
694
 
    perror("setgid");
 
835
    error(0, errno, "setgid");
695
836
  }
696
837
  ret = setuid(uid);
697
838
  if(ret == -1){
698
 
    perror("setuid");
699
 
  }
700
 
  
701
 
  if(plugindir == NULL){
702
 
    dir = opendir(PDIR);
703
 
  } else {
704
 
    dir = opendir(plugindir);
705
 
  }
706
 
  
707
 
  if(dir == NULL){
708
 
    perror("Could not open plugin dir");
709
 
    exitstatus = EXIT_FAILURE;
710
 
    goto fallback;
711
 
  }
712
 
  
713
 
  /* Set the FD_CLOEXEC flag on the directory, if possible */
 
839
    error(0, errno, "setuid");
 
840
  }
 
841
  
 
842
  /* Open plugin directory with close_on_exec flag */
714
843
  {
715
 
    int dir_fd = dirfd(dir);
716
 
    if(dir_fd >= 0){
717
 
      ret = set_cloexec_flag(dir_fd);
718
 
      if(ret < 0){
719
 
        perror("set_cloexec_flag");
720
 
        exitstatus = EXIT_FAILURE;
721
 
        goto fallback;
 
844
    dir_fd = open(plugindir != NULL ? plugindir : PDIR, O_RDONLY |
 
845
#ifdef O_CLOEXEC
 
846
                  O_CLOEXEC
 
847
#else  /* not O_CLOEXEC */
 
848
                  0
 
849
#endif  /* not O_CLOEXEC */
 
850
                  );
 
851
    if(dir_fd == -1){
 
852
      error(0, errno, "Could not open plugin dir");
 
853
      exitstatus = EX_UNAVAILABLE;
 
854
      goto fallback;
 
855
    }
 
856
    
 
857
#ifndef O_CLOEXEC
 
858
  /* Set the FD_CLOEXEC flag on the directory */
 
859
    ret = set_cloexec_flag(dir_fd);
 
860
    if(ret < 0){
 
861
      error(0, errno, "set_cloexec_flag");
 
862
      exitstatus = EX_OSERR;
 
863
      goto fallback;
 
864
    }
 
865
#endif  /* O_CLOEXEC */
 
866
  }
 
867
  
 
868
  int good_name(const struct dirent * const dirent){
 
869
    const char * const patterns[] = { ".*", "#*#", "*~", "*.dpkg-new",
 
870
                                      "*.dpkg-old", "*.dpkg-bak",
 
871
                                      "*.dpkg-divert", NULL };
 
872
#ifdef __GNUC__
 
873
#pragma GCC diagnostic push
 
874
#pragma GCC diagnostic ignored "-Wcast-qual"
 
875
#endif
 
876
    for(const char **pat = (const char **)patterns;
 
877
        *pat != NULL; pat++){
 
878
#ifdef __GNUC__
 
879
#pragma GCC diagnostic pop
 
880
#endif
 
881
      if(fnmatch(*pat, dirent->d_name, FNM_FILE_NAME | FNM_PERIOD)
 
882
         != FNM_NOMATCH){
 
883
        if(debug){
 
884
            fprintf(stderr, "Ignoring plugin dir entry \"%s\""
 
885
                    " matching pattern %s\n", dirent->d_name, *pat);
 
886
        }
 
887
        return 0;
722
888
      }
723
889
    }
 
890
    return 1;
 
891
  }
 
892
  
 
893
  int numplugins = scandirat(dir_fd, ".", &direntries, good_name,
 
894
                             alphasort);
 
895
  if(numplugins == -1){
 
896
    error(0, errno, "Could not scan plugin dir");
 
897
    direntries = NULL;
 
898
    exitstatus = EX_OSERR;
 
899
    goto fallback;
724
900
  }
725
901
  
726
902
  FD_ZERO(&rfds_all);
727
903
  
728
904
  /* Read and execute any executable in the plugin directory*/
729
 
  while(true){
730
 
    do {
731
 
      dirst = readdir(dir);
732
 
    } while(dirst == NULL and errno == EINTR);
733
 
    
734
 
    /* All directory entries have been processed */
735
 
    if(dirst == NULL){
736
 
      if(errno == EBADF){
737
 
        perror("readdir");
738
 
        exitstatus = EXIT_FAILURE;
739
 
        goto fallback;
740
 
      }
741
 
      break;
742
 
    }
743
 
    
744
 
    d_name_len = strlen(dirst->d_name);
745
 
    
746
 
    /* Ignore dotfiles, backup files and other junk */
747
 
    {
748
 
      bool bad_name = false;
749
 
      
750
 
      const char const *bad_prefixes[] = { ".", "#", NULL };
751
 
      
752
 
      const char const *bad_suffixes[] = { "~", "#", ".dpkg-new",
753
 
                                           ".dpkg-old",
754
 
                                           ".dpkg-bak",
755
 
                                           ".dpkg-divert", NULL };
756
 
      for(const char **pre = bad_prefixes; *pre != NULL; pre++){
757
 
        size_t pre_len = strlen(*pre);
758
 
        if((d_name_len >= pre_len)
759
 
           and strncmp((dirst->d_name), *pre, pre_len) == 0){
760
 
          if(debug){
761
 
            fprintf(stderr, "Ignoring plugin dir entry \"%s\""
762
 
                    " with bad prefix %s\n", dirst->d_name, *pre);
763
 
          }
764
 
          bad_name = true;
765
 
          break;
766
 
        }
767
 
      }
768
 
      if(bad_name){
769
 
        continue;
770
 
      }
771
 
      for(const char **suf = bad_suffixes; *suf != NULL; suf++){
772
 
        size_t suf_len = strlen(*suf);
773
 
        if((d_name_len >= suf_len)
774
 
           and (strcmp((dirst->d_name)+d_name_len-suf_len, *suf)
775
 
                == 0)){
776
 
          if(debug){
777
 
            fprintf(stderr, "Ignoring plugin dir entry \"%s\""
778
 
                    " with bad suffix %s\n", dirst->d_name, *suf);
779
 
          }
780
 
          bad_name = true;
781
 
          break;
782
 
        }
783
 
      }
784
 
      
785
 
      if(bad_name){
786
 
        continue;
787
 
      }
788
 
    }
789
 
    
790
 
    char *filename;
791
 
    if(plugindir == NULL){
792
 
      ret = (int)TEMP_FAILURE_RETRY(asprintf(&filename, PDIR "/%s",
793
 
                                             dirst->d_name));
794
 
    } else {
795
 
      ret = (int)TEMP_FAILURE_RETRY(asprintf(&filename, "%s/%s",
796
 
                                             plugindir,
797
 
                                             dirst->d_name));
798
 
    }
799
 
    if(ret < 0){
800
 
      perror("asprintf");
 
905
  for(int i = 0; i < numplugins; i++){
 
906
    
 
907
    int plugin_fd = openat(dir_fd, direntries[i]->d_name, O_RDONLY);
 
908
    if(plugin_fd == -1){
 
909
      error(0, errno, "Could not open plugin");
 
910
      free(direntries[i]);
801
911
      continue;
802
912
    }
803
 
    
804
 
    ret = (int)TEMP_FAILURE_RETRY(stat(filename, &st));
 
913
    ret = (int)TEMP_FAILURE_RETRY(fstat(plugin_fd, &st));
805
914
    if(ret == -1){
806
 
      perror("stat");
807
 
      free(filename);
 
915
      error(0, errno, "stat");
 
916
      close(plugin_fd);
 
917
      free(direntries[i]);
808
918
      continue;
809
919
    }
810
920
    
811
921
    /* Ignore non-executable files */
812
922
    if(not S_ISREG(st.st_mode)
813
 
       or (TEMP_FAILURE_RETRY(access(filename, X_OK)) != 0)){
 
923
       or (TEMP_FAILURE_RETRY(faccessat(dir_fd, direntries[i]->d_name,
 
924
                                        X_OK, 0)) != 0)){
814
925
      if(debug){
815
 
        fprintf(stderr, "Ignoring plugin dir entry \"%s\""
816
 
                " with bad type or mode\n", filename);
 
926
        fprintf(stderr, "Ignoring plugin dir entry \"%s/%s\""
 
927
                " with bad type or mode\n",
 
928
                plugindir != NULL ? plugindir : PDIR,
 
929
                direntries[i]->d_name);
817
930
      }
818
 
      free(filename);
 
931
      close(plugin_fd);
 
932
      free(direntries[i]);
819
933
      continue;
820
934
    }
821
935
    
822
 
    plugin *p = getplugin(dirst->d_name);
 
936
    plugin *p = getplugin(direntries[i]->d_name);
823
937
    if(p == NULL){
824
 
      perror("getplugin");
825
 
      free(filename);
 
938
      error(0, errno, "getplugin");
 
939
      close(plugin_fd);
 
940
      free(direntries[i]);
826
941
      continue;
827
942
    }
828
943
    if(p->disabled){
829
944
      if(debug){
830
945
        fprintf(stderr, "Ignoring disabled plugin \"%s\"\n",
831
 
                dirst->d_name);
 
946
                direntries[i]->d_name);
832
947
      }
833
 
      free(filename);
 
948
      close(plugin_fd);
 
949
      free(direntries[i]);
834
950
      continue;
835
951
    }
836
952
    {
839
955
      if(g != NULL){
840
956
        for(char **a = g->argv + 1; *a != NULL; a++){
841
957
          if(not add_argument(p, *a)){
842
 
            perror("add_argument");
 
958
            error(0, errno, "add_argument");
843
959
          }
844
960
        }
845
961
        /* Add global environment variables */
846
962
        for(char **e = g->environ; *e != NULL; e++){
847
963
          if(not add_environment(p, *e, false)){
848
 
            perror("add_environment");
 
964
            error(0, errno, "add_environment");
849
965
          }
850
966
        }
851
967
      }
852
968
    }
853
 
    /* If this plugin has any environment variables, we will call
854
 
       using execve and need to duplicate the environment from this
855
 
       process, too. */
 
969
    /* If this plugin has any environment variables, we need to
 
970
       duplicate the environment from this process, too. */
856
971
    if(p->environ[0] != NULL){
857
972
      for(char **e = environ; *e != NULL; e++){
858
973
        if(not add_environment(p, *e, false)){
859
 
          perror("add_environment");
 
974
          error(0, errno, "add_environment");
860
975
        }
861
976
      }
862
977
    }
863
978
    
864
979
    int pipefd[2];
 
980
#ifndef O_CLOEXEC
865
981
    ret = (int)TEMP_FAILURE_RETRY(pipe(pipefd));
 
982
#else  /* O_CLOEXEC */
 
983
    ret = (int)TEMP_FAILURE_RETRY(pipe2(pipefd, O_CLOEXEC));
 
984
#endif  /* O_CLOEXEC */
866
985
    if(ret == -1){
867
 
      perror("pipe");
868
 
      exitstatus = EXIT_FAILURE;
869
 
      goto fallback;
870
 
    }
 
986
      error(0, errno, "pipe");
 
987
      exitstatus = EX_OSERR;
 
988
      free(direntries[i]);
 
989
      goto fallback;
 
990
    }
 
991
    if(pipefd[0] >= FD_SETSIZE){
 
992
      fprintf(stderr, "pipe()[0] (%d) >= FD_SETSIZE (%d)", pipefd[0],
 
993
              FD_SETSIZE);
 
994
      close(pipefd[0]);
 
995
      close(pipefd[1]);
 
996
      exitstatus = EX_OSERR;
 
997
      free(direntries[i]);
 
998
      goto fallback;
 
999
    }
 
1000
#ifndef O_CLOEXEC
871
1001
    /* Ask OS to automatic close the pipe on exec */
872
1002
    ret = set_cloexec_flag(pipefd[0]);
873
1003
    if(ret < 0){
874
 
      perror("set_cloexec_flag");
875
 
      exitstatus = EXIT_FAILURE;
 
1004
      error(0, errno, "set_cloexec_flag");
 
1005
      close(pipefd[0]);
 
1006
      close(pipefd[1]);
 
1007
      exitstatus = EX_OSERR;
 
1008
      free(direntries[i]);
876
1009
      goto fallback;
877
1010
    }
878
1011
    ret = set_cloexec_flag(pipefd[1]);
879
1012
    if(ret < 0){
880
 
      perror("set_cloexec_flag");
881
 
      exitstatus = EXIT_FAILURE;
 
1013
      error(0, errno, "set_cloexec_flag");
 
1014
      close(pipefd[0]);
 
1015
      close(pipefd[1]);
 
1016
      exitstatus = EX_OSERR;
 
1017
      free(direntries[i]);
882
1018
      goto fallback;
883
1019
    }
 
1020
#endif  /* not O_CLOEXEC */
884
1021
    /* Block SIGCHLD until process is safely in process list */
885
1022
    ret = (int)TEMP_FAILURE_RETRY(sigprocmask(SIG_BLOCK,
886
1023
                                              &sigchld_action.sa_mask,
887
1024
                                              NULL));
888
1025
    if(ret < 0){
889
 
      perror("sigprocmask");
890
 
      exitstatus = EXIT_FAILURE;
 
1026
      error(0, errno, "sigprocmask");
 
1027
      exitstatus = EX_OSERR;
 
1028
      free(direntries[i]);
891
1029
      goto fallback;
892
1030
    }
893
1031
    /* Starting a new process to be watched */
896
1034
      pid = fork();
897
1035
    } while(pid == -1 and errno == EINTR);
898
1036
    if(pid == -1){
899
 
      perror("fork");
900
 
      exitstatus = EXIT_FAILURE;
 
1037
      error(0, errno, "fork");
 
1038
      TEMP_FAILURE_RETRY(sigprocmask(SIG_UNBLOCK,
 
1039
                                     &sigchld_action.sa_mask, NULL));
 
1040
      close(pipefd[0]);
 
1041
      close(pipefd[1]);
 
1042
      exitstatus = EX_OSERR;
 
1043
      free(direntries[i]);
901
1044
      goto fallback;
902
1045
    }
903
1046
    if(pid == 0){
904
1047
      /* this is the child process */
905
1048
      ret = sigaction(SIGCHLD, &old_sigchld_action, NULL);
906
1049
      if(ret < 0){
907
 
        perror("sigaction");
908
 
        _exit(EXIT_FAILURE);
 
1050
        error(0, errno, "sigaction");
 
1051
        _exit(EX_OSERR);
909
1052
      }
910
1053
      ret = sigprocmask(SIG_UNBLOCK, &sigchld_action.sa_mask, NULL);
911
1054
      if(ret < 0){
912
 
        perror("sigprocmask");
913
 
        _exit(EXIT_FAILURE);
 
1055
        error(0, errno, "sigprocmask");
 
1056
        _exit(EX_OSERR);
914
1057
      }
915
1058
      
916
1059
      ret = dup2(pipefd[1], STDOUT_FILENO); /* replace our stdout */
917
1060
      if(ret == -1){
918
 
        perror("dup2");
919
 
        _exit(EXIT_FAILURE);
 
1061
        error(0, errno, "dup2");
 
1062
        _exit(EX_OSERR);
920
1063
      }
921
1064
      
922
 
      if(dirfd(dir) < 0){
923
 
        /* If dir has no file descriptor, we could not set FD_CLOEXEC
924
 
           above and must now close it manually here. */
925
 
        closedir(dir);
926
 
      }
927
 
      if(p->environ[0] == NULL){
928
 
        if(execv(filename, p->argv) < 0){
929
 
          perror("execv");
930
 
          _exit(EXIT_FAILURE);
931
 
        }
932
 
      } else {
933
 
        if(execve(filename, p->argv, p->environ) < 0){
934
 
          perror("execve");
935
 
          _exit(EXIT_FAILURE);
936
 
        }
 
1065
      if(fexecve(plugin_fd, p->argv,
 
1066
                (p->environ[0] != NULL) ? p->environ : environ) < 0){
 
1067
        error(0, errno, "fexecve for %s/%s",
 
1068
              plugindir != NULL ? plugindir : PDIR,
 
1069
              direntries[i]->d_name);
 
1070
        _exit(EX_OSERR);
937
1071
      }
938
1072
      /* no return */
939
1073
    }
940
1074
    /* Parent process */
941
 
    TEMP_FAILURE_RETRY(close(pipefd[1])); /* Close unused write end of
942
 
                                             pipe */
943
 
    free(filename);
944
 
    plugin *new_plugin = getplugin(dirst->d_name);
 
1075
    close(pipefd[1]);           /* Close unused write end of pipe */
 
1076
    close(plugin_fd);
 
1077
    plugin *new_plugin = getplugin(direntries[i]->d_name);
945
1078
    if(new_plugin == NULL){
946
 
      perror("getplugin");
 
1079
      error(0, errno, "getplugin");
947
1080
      ret = (int)(TEMP_FAILURE_RETRY
948
1081
                  (sigprocmask(SIG_UNBLOCK, &sigchld_action.sa_mask,
949
1082
                               NULL)));
950
1083
      if(ret < 0){
951
 
        perror("sigprocmask");
 
1084
        error(0, errno, "sigprocmask");
952
1085
      }
953
 
      exitstatus = EXIT_FAILURE;
 
1086
      exitstatus = EX_OSERR;
 
1087
      free(direntries[i]);
954
1088
      goto fallback;
955
1089
    }
 
1090
    free(direntries[i]);
956
1091
    
957
1092
    new_plugin->pid = pid;
958
1093
    new_plugin->fd = pipefd[0];
963
1098
                                              &sigchld_action.sa_mask,
964
1099
                                              NULL));
965
1100
    if(ret < 0){
966
 
      perror("sigprocmask");
967
 
      exitstatus = EXIT_FAILURE;
 
1101
      error(0, errno, "sigprocmask");
 
1102
      exitstatus = EX_OSERR;
968
1103
      goto fallback;
969
1104
    }
970
1105
    
975
1110
    }
976
1111
  }
977
1112
  
978
 
  TEMP_FAILURE_RETRY(closedir(dir));
979
 
  dir = NULL;
 
1113
  free(direntries);
 
1114
  direntries = NULL;
 
1115
  close(dir_fd);
 
1116
  dir_fd = -1;
980
1117
  free_plugin(getplugin(NULL));
981
1118
  
982
1119
  for(plugin *p = plugin_list; p != NULL; p = p->next){
995
1132
    fd_set rfds = rfds_all;
996
1133
    int select_ret = select(maxfd+1, &rfds, NULL, NULL, NULL);
997
1134
    if(select_ret == -1 and errno != EINTR){
998
 
      perror("select");
999
 
      exitstatus = EXIT_FAILURE;
 
1135
      error(0, errno, "select");
 
1136
      exitstatus = EX_OSERR;
1000
1137
      goto fallback;
1001
1138
    }
1002
1139
    /* OK, now either a process completed, or something can be read
1021
1158
                      (intmax_t) (proc->pid),
1022
1159
                      WTERMSIG(proc->status),
1023
1160
                      strsignal(WTERMSIG(proc->status)));
1024
 
            } else if(WCOREDUMP(proc->status)){
1025
 
              fprintf(stderr, "Plugin %s [%" PRIdMAX "] dumped"
1026
 
                      " core\n", proc->name, (intmax_t) (proc->pid));
1027
1161
            }
1028
1162
          }
1029
1163
          
1036
1170
                                         &sigchld_action.sa_mask,
1037
1171
                                         NULL));
1038
1172
          if(ret < 0){
1039
 
            perror("sigprocmask");
1040
 
            exitstatus = EXIT_FAILURE;
 
1173
            error(0, errno, "sigprocmask");
 
1174
            exitstatus = EX_OSERR;
1041
1175
            goto fallback;
1042
1176
          }
1043
1177
          
1050
1184
                      (sigprocmask(SIG_UNBLOCK,
1051
1185
                                   &sigchld_action.sa_mask, NULL)));
1052
1186
          if(ret < 0){
1053
 
            perror("sigprocmask");
1054
 
            exitstatus = EXIT_FAILURE;
 
1187
            error(0, errno, "sigprocmask");
 
1188
            exitstatus = EX_OSERR;
1055
1189
            goto fallback;
1056
1190
          }
1057
1191
          
1067
1201
        bool bret = print_out_password(proc->buffer,
1068
1202
                                       proc->buffer_length);
1069
1203
        if(not bret){
1070
 
          perror("print_out_password");
1071
 
          exitstatus = EXIT_FAILURE;
 
1204
          error(0, errno, "print_out_password");
 
1205
          exitstatus = EX_IOERR;
1072
1206
        }
1073
1207
        goto fallback;
1074
1208
      }
1081
1215
      }
1082
1216
      /* Before reading, make the process' data buffer large enough */
1083
1217
      if(proc->buffer_length + BUFFER_SIZE > proc->buffer_size){
1084
 
        proc->buffer = realloc(proc->buffer, proc->buffer_size
1085
 
                               + (size_t) BUFFER_SIZE);
1086
 
        if(proc->buffer == NULL){
1087
 
          perror("malloc");
1088
 
          exitstatus = EXIT_FAILURE;
 
1218
        char *new_buffer = realloc(proc->buffer, proc->buffer_size
 
1219
                                   + (size_t) BUFFER_SIZE);
 
1220
        if(new_buffer == NULL){
 
1221
          error(0, errno, "malloc");
 
1222
          exitstatus = EX_OSERR;
1089
1223
          goto fallback;
1090
1224
        }
 
1225
        proc->buffer = new_buffer;
1091
1226
        proc->buffer_size += BUFFER_SIZE;
1092
1227
      }
1093
1228
      /* Read from the process */
1112
1247
  
1113
1248
 fallback:
1114
1249
  
1115
 
  if(plugin_list == NULL or exitstatus != EXIT_SUCCESS){
 
1250
  if(plugin_list == NULL or (exitstatus != EXIT_SUCCESS
 
1251
                             and exitstatus != EX_OK)){
1116
1252
    /* Fallback if all plugins failed, none are found or an error
1117
1253
       occured */
1118
1254
    bool bret;
1126
1262
    }
1127
1263
    bret = print_out_password(passwordbuffer, len);
1128
1264
    if(not bret){
1129
 
      perror("print_out_password");
1130
 
      exitstatus = EXIT_FAILURE;
 
1265
      error(0, errno, "print_out_password");
 
1266
      exitstatus = EX_IOERR;
1131
1267
    }
1132
1268
  }
1133
1269
  
1134
1270
  /* Restore old signal handler */
1135
1271
  ret = sigaction(SIGCHLD, &old_sigchld_action, NULL);
1136
1272
  if(ret == -1){
1137
 
    perror("sigaction");
1138
 
    exitstatus = EXIT_FAILURE;
 
1273
    error(0, errno, "sigaction");
 
1274
    exitstatus = EX_OSERR;
1139
1275
  }
1140
1276
  
1141
1277
  if(custom_argv != NULL){
1145
1281
    free(custom_argv);
1146
1282
  }
1147
1283
  
1148
 
  if(dir != NULL){
1149
 
    closedir(dir);
 
1284
  free(direntries);
 
1285
  
 
1286
  if(dir_fd != -1){
 
1287
    close(dir_fd);
1150
1288
  }
1151
1289
  
1152
1290
  /* Kill the processes */
1156
1294
      ret = kill(p->pid, SIGTERM);
1157
1295
      if(ret == -1 and errno != ESRCH){
1158
1296
        /* Set-uid proccesses might not get closed */
1159
 
        perror("kill");
 
1297
        error(0, errno, "kill");
1160
1298
      }
1161
1299
    }
1162
1300
  }
1166
1304
    ret = wait(NULL);
1167
1305
  } while(ret >= 0);
1168
1306
  if(errno != ECHILD){
1169
 
    perror("wait");
 
1307
    error(0, errno, "wait");
1170
1308
  }
1171
1309
  
1172
1310
  free_plugin_list();
1173
1311
  
1174
1312
  free(plugindir);
 
1313
  free(pluginhelperdir);
1175
1314
  free(argfile);
1176
1315
  
1177
1316
  return exitstatus;