/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

  • Committer: Teddy Hogeborn
  • Date: 2016-06-03 17:27:03 UTC
  • mto: (237.7.594 trunk)
  • mto: This revision was merged to the branch mainline in revision 343.
  • 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(), O_CLOEXEC */
 
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, fdopendir(), 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, fdopendir(),
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");
 
839
    error(0, errno, "setuid");
699
840
  }
700
841
  
701
842
  /* Open plugin directory with close_on_exec flag */
702
843
  {
703
 
    int dir_fd = -1;
704
 
    if(plugindir == NULL){
705
 
      dir_fd = open(PDIR, O_RDONLY |
706
 
#ifdef O_CLOEXEC
707
 
                    O_CLOEXEC
708
 
#else  /* not O_CLOEXEC */
709
 
                    0
710
 
#endif  /* not O_CLOEXEC */
711
 
                    );
712
 
    } else {
713
 
      dir_fd = open(plugindir, O_RDONLY |
714
 
#ifdef O_CLOEXEC
715
 
                    O_CLOEXEC
716
 
#else  /* not O_CLOEXEC */
717
 
                    0
718
 
#endif  /* not O_CLOEXEC */
719
 
                    );
720
 
    }
 
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
                  );
721
851
    if(dir_fd == -1){
722
 
      perror("Could not open plugin dir");
723
 
      exitstatus = EXIT_FAILURE;
 
852
      error(0, errno, "Could not open plugin dir");
 
853
      exitstatus = EX_UNAVAILABLE;
724
854
      goto fallback;
725
855
    }
726
856
    
728
858
  /* Set the FD_CLOEXEC flag on the directory */
729
859
    ret = set_cloexec_flag(dir_fd);
730
860
    if(ret < 0){
731
 
      perror("set_cloexec_flag");
732
 
      TEMP_FAILURE_RETRY(close(dir_fd));
733
 
      exitstatus = EXIT_FAILURE;
 
861
      error(0, errno, "set_cloexec_flag");
 
862
      exitstatus = EX_OSERR;
734
863
      goto fallback;
735
864
    }
736
865
#endif  /* O_CLOEXEC */
737
 
    
738
 
    dir = fdopendir(dir_fd);
739
 
    if(dir == NULL){
740
 
      perror("Could not open plugin dir");
741
 
      TEMP_FAILURE_RETRY(close(dir_fd));
742
 
      exitstatus = EXIT_FAILURE;
743
 
      goto fallback;
 
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;
 
888
      }
744
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;
745
900
  }
746
901
  
747
902
  FD_ZERO(&rfds_all);
748
903
  
749
904
  /* Read and execute any executable in the plugin directory*/
750
 
  while(true){
751
 
    do {
752
 
      dirst = readdir(dir);
753
 
    } while(dirst == NULL and errno == EINTR);
754
 
    
755
 
    /* All directory entries have been processed */
756
 
    if(dirst == NULL){
757
 
      if(errno == EBADF){
758
 
        perror("readdir");
759
 
        exitstatus = EXIT_FAILURE;
760
 
        goto fallback;
761
 
      }
762
 
      break;
763
 
    }
764
 
    
765
 
    d_name_len = strlen(dirst->d_name);
766
 
    
767
 
    /* Ignore dotfiles, backup files and other junk */
768
 
    {
769
 
      bool bad_name = false;
770
 
      
771
 
      const char const *bad_prefixes[] = { ".", "#", NULL };
772
 
      
773
 
      const char const *bad_suffixes[] = { "~", "#", ".dpkg-new",
774
 
                                           ".dpkg-old",
775
 
                                           ".dpkg-bak",
776
 
                                           ".dpkg-divert", NULL };
777
 
      for(const char **pre = bad_prefixes; *pre != NULL; pre++){
778
 
        size_t pre_len = strlen(*pre);
779
 
        if((d_name_len >= pre_len)
780
 
           and strncmp((dirst->d_name), *pre, pre_len) == 0){
781
 
          if(debug){
782
 
            fprintf(stderr, "Ignoring plugin dir entry \"%s\""
783
 
                    " with bad prefix %s\n", dirst->d_name, *pre);
784
 
          }
785
 
          bad_name = true;
786
 
          break;
787
 
        }
788
 
      }
789
 
      if(bad_name){
790
 
        continue;
791
 
      }
792
 
      for(const char **suf = bad_suffixes; *suf != NULL; suf++){
793
 
        size_t suf_len = strlen(*suf);
794
 
        if((d_name_len >= suf_len)
795
 
           and (strcmp((dirst->d_name)+d_name_len-suf_len, *suf)
796
 
                == 0)){
797
 
          if(debug){
798
 
            fprintf(stderr, "Ignoring plugin dir entry \"%s\""
799
 
                    " with bad suffix %s\n", dirst->d_name, *suf);
800
 
          }
801
 
          bad_name = true;
802
 
          break;
803
 
        }
804
 
      }
805
 
      
806
 
      if(bad_name){
807
 
        continue;
808
 
      }
809
 
    }
810
 
    
811
 
    char *filename;
812
 
    if(plugindir == NULL){
813
 
      ret = (int)TEMP_FAILURE_RETRY(asprintf(&filename, PDIR "/%s",
814
 
                                             dirst->d_name));
815
 
    } else {
816
 
      ret = (int)TEMP_FAILURE_RETRY(asprintf(&filename, "%s/%s",
817
 
                                             plugindir,
818
 
                                             dirst->d_name));
819
 
    }
820
 
    if(ret < 0){
821
 
      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]);
822
911
      continue;
823
912
    }
824
 
    
825
 
    ret = (int)TEMP_FAILURE_RETRY(stat(filename, &st));
 
913
    ret = (int)TEMP_FAILURE_RETRY(fstat(plugin_fd, &st));
826
914
    if(ret == -1){
827
 
      perror("stat");
828
 
      free(filename);
 
915
      error(0, errno, "stat");
 
916
      close(plugin_fd);
 
917
      free(direntries[i]);
829
918
      continue;
830
919
    }
831
920
    
832
921
    /* Ignore non-executable files */
833
922
    if(not S_ISREG(st.st_mode)
834
 
       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)){
835
925
      if(debug){
836
 
        fprintf(stderr, "Ignoring plugin dir entry \"%s\""
837
 
                " 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);
838
930
      }
839
 
      free(filename);
 
931
      close(plugin_fd);
 
932
      free(direntries[i]);
840
933
      continue;
841
934
    }
842
935
    
843
 
    plugin *p = getplugin(dirst->d_name);
 
936
    plugin *p = getplugin(direntries[i]->d_name);
844
937
    if(p == NULL){
845
 
      perror("getplugin");
846
 
      free(filename);
 
938
      error(0, errno, "getplugin");
 
939
      close(plugin_fd);
 
940
      free(direntries[i]);
847
941
      continue;
848
942
    }
849
943
    if(p->disabled){
850
944
      if(debug){
851
945
        fprintf(stderr, "Ignoring disabled plugin \"%s\"\n",
852
 
                dirst->d_name);
 
946
                direntries[i]->d_name);
853
947
      }
854
 
      free(filename);
 
948
      close(plugin_fd);
 
949
      free(direntries[i]);
855
950
      continue;
856
951
    }
857
952
    {
860
955
      if(g != NULL){
861
956
        for(char **a = g->argv + 1; *a != NULL; a++){
862
957
          if(not add_argument(p, *a)){
863
 
            perror("add_argument");
 
958
            error(0, errno, "add_argument");
864
959
          }
865
960
        }
866
961
        /* Add global environment variables */
867
962
        for(char **e = g->environ; *e != NULL; e++){
868
963
          if(not add_environment(p, *e, false)){
869
 
            perror("add_environment");
 
964
            error(0, errno, "add_environment");
870
965
          }
871
966
        }
872
967
      }
873
968
    }
874
 
    /* If this plugin has any environment variables, we will call
875
 
       using execve and need to duplicate the environment from this
876
 
       process, too. */
 
969
    /* If this plugin has any environment variables, we need to
 
970
       duplicate the environment from this process, too. */
877
971
    if(p->environ[0] != NULL){
878
972
      for(char **e = environ; *e != NULL; e++){
879
973
        if(not add_environment(p, *e, false)){
880
 
          perror("add_environment");
 
974
          error(0, errno, "add_environment");
881
975
        }
882
976
      }
883
977
    }
884
978
    
885
979
    int pipefd[2];
 
980
#ifndef O_CLOEXEC
886
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 */
887
985
    if(ret == -1){
888
 
      perror("pipe");
889
 
      exitstatus = EXIT_FAILURE;
890
 
      goto fallback;
891
 
    }
 
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
892
1001
    /* Ask OS to automatic close the pipe on exec */
893
1002
    ret = set_cloexec_flag(pipefd[0]);
894
1003
    if(ret < 0){
895
 
      perror("set_cloexec_flag");
896
 
      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]);
897
1009
      goto fallback;
898
1010
    }
899
1011
    ret = set_cloexec_flag(pipefd[1]);
900
1012
    if(ret < 0){
901
 
      perror("set_cloexec_flag");
902
 
      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]);
903
1018
      goto fallback;
904
1019
    }
 
1020
#endif  /* not O_CLOEXEC */
905
1021
    /* Block SIGCHLD until process is safely in process list */
906
1022
    ret = (int)TEMP_FAILURE_RETRY(sigprocmask(SIG_BLOCK,
907
1023
                                              &sigchld_action.sa_mask,
908
1024
                                              NULL));
909
1025
    if(ret < 0){
910
 
      perror("sigprocmask");
911
 
      exitstatus = EXIT_FAILURE;
 
1026
      error(0, errno, "sigprocmask");
 
1027
      exitstatus = EX_OSERR;
 
1028
      free(direntries[i]);
912
1029
      goto fallback;
913
1030
    }
914
1031
    /* Starting a new process to be watched */
917
1034
      pid = fork();
918
1035
    } while(pid == -1 and errno == EINTR);
919
1036
    if(pid == -1){
920
 
      perror("fork");
921
 
      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]);
922
1044
      goto fallback;
923
1045
    }
924
1046
    if(pid == 0){
925
1047
      /* this is the child process */
926
1048
      ret = sigaction(SIGCHLD, &old_sigchld_action, NULL);
927
1049
      if(ret < 0){
928
 
        perror("sigaction");
929
 
        _exit(EXIT_FAILURE);
 
1050
        error(0, errno, "sigaction");
 
1051
        _exit(EX_OSERR);
930
1052
      }
931
1053
      ret = sigprocmask(SIG_UNBLOCK, &sigchld_action.sa_mask, NULL);
932
1054
      if(ret < 0){
933
 
        perror("sigprocmask");
934
 
        _exit(EXIT_FAILURE);
 
1055
        error(0, errno, "sigprocmask");
 
1056
        _exit(EX_OSERR);
935
1057
      }
936
1058
      
937
1059
      ret = dup2(pipefd[1], STDOUT_FILENO); /* replace our stdout */
938
1060
      if(ret == -1){
939
 
        perror("dup2");
940
 
        _exit(EXIT_FAILURE);
 
1061
        error(0, errno, "dup2");
 
1062
        _exit(EX_OSERR);
941
1063
      }
942
1064
      
943
 
      if(dirfd(dir) < 0){
944
 
        /* If dir has no file descriptor, we could not set FD_CLOEXEC
945
 
           above and must now close it manually here. */
946
 
        closedir(dir);
947
 
      }
948
 
      if(p->environ[0] == NULL){
949
 
        if(execv(filename, p->argv) < 0){
950
 
          perror("execv");
951
 
          _exit(EXIT_FAILURE);
952
 
        }
953
 
      } else {
954
 
        if(execve(filename, p->argv, p->environ) < 0){
955
 
          perror("execve");
956
 
          _exit(EXIT_FAILURE);
957
 
        }
 
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);
958
1071
      }
959
1072
      /* no return */
960
1073
    }
961
1074
    /* Parent process */
962
 
    TEMP_FAILURE_RETRY(close(pipefd[1])); /* Close unused write end of
963
 
                                             pipe */
964
 
    free(filename);
965
 
    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);
966
1078
    if(new_plugin == NULL){
967
 
      perror("getplugin");
 
1079
      error(0, errno, "getplugin");
968
1080
      ret = (int)(TEMP_FAILURE_RETRY
969
1081
                  (sigprocmask(SIG_UNBLOCK, &sigchld_action.sa_mask,
970
1082
                               NULL)));
971
1083
      if(ret < 0){
972
 
        perror("sigprocmask");
 
1084
        error(0, errno, "sigprocmask");
973
1085
      }
974
 
      exitstatus = EXIT_FAILURE;
 
1086
      exitstatus = EX_OSERR;
 
1087
      free(direntries[i]);
975
1088
      goto fallback;
976
1089
    }
 
1090
    free(direntries[i]);
977
1091
    
978
1092
    new_plugin->pid = pid;
979
1093
    new_plugin->fd = pipefd[0];
984
1098
                                              &sigchld_action.sa_mask,
985
1099
                                              NULL));
986
1100
    if(ret < 0){
987
 
      perror("sigprocmask");
988
 
      exitstatus = EXIT_FAILURE;
 
1101
      error(0, errno, "sigprocmask");
 
1102
      exitstatus = EX_OSERR;
989
1103
      goto fallback;
990
1104
    }
991
1105
    
992
 
    FD_SET(new_plugin->fd, &rfds_all); /* Spurious warning from
993
 
                                          -Wconversion */
 
1106
    FD_SET(new_plugin->fd, &rfds_all);
994
1107
    
995
1108
    if(maxfd < new_plugin->fd){
996
1109
      maxfd = new_plugin->fd;
997
1110
    }
998
1111
  }
999
1112
  
1000
 
  TEMP_FAILURE_RETRY(closedir(dir));
1001
 
  dir = NULL;
 
1113
  free(direntries);
 
1114
  direntries = NULL;
 
1115
  close(dir_fd);
 
1116
  dir_fd = -1;
1002
1117
  free_plugin(getplugin(NULL));
1003
1118
  
1004
1119
  for(plugin *p = plugin_list; p != NULL; p = p->next){
1017
1132
    fd_set rfds = rfds_all;
1018
1133
    int select_ret = select(maxfd+1, &rfds, NULL, NULL, NULL);
1019
1134
    if(select_ret == -1 and errno != EINTR){
1020
 
      perror("select");
1021
 
      exitstatus = EXIT_FAILURE;
 
1135
      error(0, errno, "select");
 
1136
      exitstatus = EX_OSERR;
1022
1137
      goto fallback;
1023
1138
    }
1024
1139
    /* OK, now either a process completed, or something can be read
1043
1158
                      (intmax_t) (proc->pid),
1044
1159
                      WTERMSIG(proc->status),
1045
1160
                      strsignal(WTERMSIG(proc->status)));
1046
 
            } else if(WCOREDUMP(proc->status)){
1047
 
              fprintf(stderr, "Plugin %s [%" PRIdMAX "] dumped"
1048
 
                      " core\n", proc->name, (intmax_t) (proc->pid));
1049
1161
            }
1050
1162
          }
1051
1163
          
1052
1164
          /* Remove the plugin */
1053
 
          FD_CLR(proc->fd, &rfds_all); /* Spurious warning from
1054
 
                                          -Wconversion */
 
1165
          FD_CLR(proc->fd, &rfds_all);
1055
1166
          
1056
1167
          /* Block signal while modifying process_list */
1057
1168
          ret = (int)TEMP_FAILURE_RETRY(sigprocmask
1059
1170
                                         &sigchld_action.sa_mask,
1060
1171
                                         NULL));
1061
1172
          if(ret < 0){
1062
 
            perror("sigprocmask");
1063
 
            exitstatus = EXIT_FAILURE;
 
1173
            error(0, errno, "sigprocmask");
 
1174
            exitstatus = EX_OSERR;
1064
1175
            goto fallback;
1065
1176
          }
1066
1177
          
1073
1184
                      (sigprocmask(SIG_UNBLOCK,
1074
1185
                                   &sigchld_action.sa_mask, NULL)));
1075
1186
          if(ret < 0){
1076
 
            perror("sigprocmask");
1077
 
            exitstatus = EXIT_FAILURE;
 
1187
            error(0, errno, "sigprocmask");
 
1188
            exitstatus = EX_OSERR;
1078
1189
            goto fallback;
1079
1190
          }
1080
1191
          
1090
1201
        bool bret = print_out_password(proc->buffer,
1091
1202
                                       proc->buffer_length);
1092
1203
        if(not bret){
1093
 
          perror("print_out_password");
1094
 
          exitstatus = EXIT_FAILURE;
 
1204
          error(0, errno, "print_out_password");
 
1205
          exitstatus = EX_IOERR;
1095
1206
        }
1096
1207
        goto fallback;
1097
1208
      }
1098
1209
      
1099
1210
      /* This process has not completed.  Does it have any output? */
1100
 
      if(proc->eof or not FD_ISSET(proc->fd, &rfds)){ /* Spurious
1101
 
                                                         warning from
1102
 
                                                         -Wconversion */
 
1211
      if(proc->eof or not FD_ISSET(proc->fd, &rfds)){
1103
1212
        /* This process had nothing to say at this time */
1104
1213
        proc = proc->next;
1105
1214
        continue;
1106
1215
      }
1107
1216
      /* Before reading, make the process' data buffer large enough */
1108
1217
      if(proc->buffer_length + BUFFER_SIZE > proc->buffer_size){
1109
 
        proc->buffer = realloc(proc->buffer, proc->buffer_size
1110
 
                               + (size_t) BUFFER_SIZE);
1111
 
        if(proc->buffer == NULL){
1112
 
          perror("malloc");
1113
 
          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;
1114
1223
          goto fallback;
1115
1224
        }
 
1225
        proc->buffer = new_buffer;
1116
1226
        proc->buffer_size += BUFFER_SIZE;
1117
1227
      }
1118
1228
      /* Read from the process */
1137
1247
  
1138
1248
 fallback:
1139
1249
  
1140
 
  if(plugin_list == NULL or exitstatus != EXIT_SUCCESS){
 
1250
  if(plugin_list == NULL or (exitstatus != EXIT_SUCCESS
 
1251
                             and exitstatus != EX_OK)){
1141
1252
    /* Fallback if all plugins failed, none are found or an error
1142
1253
       occured */
1143
1254
    bool bret;
1151
1262
    }
1152
1263
    bret = print_out_password(passwordbuffer, len);
1153
1264
    if(not bret){
1154
 
      perror("print_out_password");
1155
 
      exitstatus = EXIT_FAILURE;
 
1265
      error(0, errno, "print_out_password");
 
1266
      exitstatus = EX_IOERR;
1156
1267
    }
1157
1268
  }
1158
1269
  
1159
1270
  /* Restore old signal handler */
1160
1271
  ret = sigaction(SIGCHLD, &old_sigchld_action, NULL);
1161
1272
  if(ret == -1){
1162
 
    perror("sigaction");
1163
 
    exitstatus = EXIT_FAILURE;
 
1273
    error(0, errno, "sigaction");
 
1274
    exitstatus = EX_OSERR;
1164
1275
  }
1165
1276
  
1166
1277
  if(custom_argv != NULL){
1170
1281
    free(custom_argv);
1171
1282
  }
1172
1283
  
1173
 
  if(dir != NULL){
1174
 
    closedir(dir);
 
1284
  free(direntries);
 
1285
  
 
1286
  if(dir_fd != -1){
 
1287
    close(dir_fd);
1175
1288
  }
1176
1289
  
1177
1290
  /* Kill the processes */
1181
1294
      ret = kill(p->pid, SIGTERM);
1182
1295
      if(ret == -1 and errno != ESRCH){
1183
1296
        /* Set-uid proccesses might not get closed */
1184
 
        perror("kill");
 
1297
        error(0, errno, "kill");
1185
1298
      }
1186
1299
    }
1187
1300
  }
1191
1304
    ret = wait(NULL);
1192
1305
  } while(ret >= 0);
1193
1306
  if(errno != ECHILD){
1194
 
    perror("wait");
 
1307
    error(0, errno, "wait");
1195
1308
  }
1196
1309
  
1197
1310
  free_plugin_list();
1198
1311
  
1199
1312
  free(plugindir);
 
1313
  free(pluginhelperdir);
1200
1314
  free(argfile);
1201
1315
  
1202
1316
  return exitstatus;