/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: 2024-09-09 04:24:39 UTC
  • Revision ID: teddy@recompile.se-20240909042439-j85mr20uli2hnyis
Eliminate compiler warnings

Many programs use nested functions, which now result in a linker
warning about executable stack.  Hide this warning.  Also, rewrite a
loop in the plymouth plugin to avoid warning about signed overflow.
This change also makes the plugin pick the alphabetically first
process entry instead of the last, in case many plymouth processes are
found (which should be unlikely).

* Makefile (plugin-runner, dracut-module/password-agent,
  plugins.d/password-prompt, plugins.d/mandos-client,
  plugins.d/plymouth): New target; set LDFLAGS to add "-Xlinker
  --no-warn-execstack".
* plugins.d/plymouth.c (get_pid): When no pid files are found, and we
  are looking through the process list, go though it from the start
  instead of from the end, i.e. in normal alphabetical order and not
  in reverse order.

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
7
 
 * 
8
 
 * This program is free software: you can redistribute it and/or
9
 
 * modify it under the terms of the GNU General Public License as
10
 
 * published by the Free Software Foundation, either version 3 of the
11
 
 * License, or (at your option) any later version.
12
 
 * 
13
 
 * This program is distributed in the hope that it will be useful, but
 
5
 * Copyright © 2008-2022 Teddy Hogeborn
 
6
 * Copyright © 2008-2022 Björn Påhlsson
 
7
 * 
 
8
 * This file is part of Mandos.
 
9
 * 
 
10
 * Mandos is free software: you can redistribute it and/or modify it
 
11
 * under the terms of the GNU General Public License as published by
 
12
 * the Free Software Foundation, either version 3 of the License, or
 
13
 * (at your option) any later version.
 
14
 * 
 
15
 * Mandos is distributed in the hope that it will be useful, but
14
16
 * WITHOUT ANY WARRANTY; without even the implied warranty of
15
17
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
16
18
 * General Public License for more details.
17
19
 * 
18
20
 * You should have received a copy of the GNU General Public License
19
 
 * along with this program.  If not, see
20
 
 * <http://www.gnu.org/licenses/>.
 
21
 * along with Mandos.  If not, see <http://www.gnu.org/licenses/>.
21
22
 * 
22
 
 * Contact the authors at <mandos@fukt.bsnet.se>.
 
23
 * Contact the authors at <mandos@recompile.se>.
23
24
 */
24
25
 
25
 
#define _GNU_SOURCE             /* TEMP_FAILURE_RETRY(), getline(),
26
 
                                   asprintf(), O_CLOEXEC */
 
26
#define _GNU_SOURCE             /* strchrnul(), TEMP_FAILURE_RETRY(),
 
27
                                   getline(), asprintf(), O_CLOEXEC,
 
28
                                   scandirat(), pipe2() */
 
29
#include <argp.h>               /* argp_program_version,
 
30
                                   argp_program_bug_address,
 
31
                                   struct argp_option,
 
32
                                   struct argp_state, argp_error(),
 
33
                                   ARGP_NO_EXIT, argp_state_help,
 
34
                                   ARGP_HELP_STD_HELP,
 
35
                                   ARGP_HELP_USAGE, ARGP_HELP_EXIT_OK,
 
36
                                   ARGP_KEY_ARG, ARGP_ERR_UNKNOWN,
 
37
                                   struct argp, argp_parse(),
 
38
                                   ARGP_IN_ORDER, ARGP_NO_HELP */
 
39
#include <stdbool.h>            /* bool, false, true */
 
40
#include <sys/types.h>          /* pid_t, sig_atomic_t, uid_t, gid_t,
 
41
                                   getuid(), setgid(), setuid() */
27
42
#include <stddef.h>             /* size_t, NULL */
28
 
#include <stdlib.h>             /* malloc(), exit(), EXIT_SUCCESS,
29
 
                                   realloc() */
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() */
38
 
#include <sys/select.h>         /* fd_set, select(), FD_ZERO(),
39
 
                                   FD_SET(), FD_ISSET(), FD_CLR */
40
 
#include <sys/wait.h>           /* wait(), waitpid(), WIFEXITED(),
41
 
                                   WEXITSTATUS(), WTERMSIG(),
42
 
                                   WCOREDUMP() */
43
 
#include <sys/stat.h>           /* struct stat, stat(), S_ISREG() */
44
 
#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 <iso646.h>             /* or, and, not */
 
44
#include <string.h>             /* strcmp(), strdup(), strchrnul(),
 
45
                                   strncmp(), strlen(), strcpy(),
 
46
                                   strsep(), strchr(), strsignal() */
 
47
#include <stdlib.h>             /* malloc(), free(), reallocarray(),
 
48
                                   realloc(), EXIT_SUCCESS */
 
49
#include <errno.h>              /* errno, EINTR, ENOMEM, ECHILD,
 
50
                                   error_t, EINVAL, EMFILE, ENFILE,
 
51
                                   ENOENT, ESRCH */
 
52
#include <stdint.h>             /* SIZE_MAX */
 
53
#define _GNU_SOURCE             /* strchrnul(), TEMP_FAILURE_RETRY(),
 
54
                                   getline(), asprintf(), O_CLOEXEC,
 
55
                                   scandirat(), pipe2() */
 
56
#include <unistd.h>             /* TEMP_FAILURE_RETRY(), ssize_t,
 
57
                                   write(), STDOUT_FILENO, uid_t,
 
58
                                   gid_t, getuid(), fchown(), close(),
 
59
                                   symlink(), setgid(), setuid(),
 
60
                                   faccessat(), X_OK, pipe(), pipe2(),
 
61
                                   fork(), _exit(), dup2(), fexecve(),
 
62
                                   read(), getpass() */
54
63
#include <fcntl.h>              /* fcntl(), F_GETFD, F_SETFD,
55
 
                                   FD_CLOEXEC */
56
 
#include <string.h>             /* strsep, strlen(), asprintf(),
57
 
                                   strsignal() */
58
 
#include <errno.h>              /* errno */
59
 
#include <argp.h>               /* struct argp_option, struct
60
 
                                   argp_state, struct argp,
61
 
                                   argp_parse(), ARGP_ERR_UNKNOWN,
62
 
                                   ARGP_KEY_END, ARGP_KEY_ARG,
63
 
                                   error_t */
64
 
#include <signal.h>             /* struct sigaction, sigemptyset(),
65
 
                                   sigaddset(), sigaction(),
66
 
                                   sigprocmask(), SIG_BLOCK, SIGCHLD,
67
 
                                   SIG_UNBLOCK, kill(), sig_atomic_t
68
 
                                */
69
 
#include <errno.h>              /* errno, EBADF */
70
 
#include <inttypes.h>           /* intmax_t, PRIdMAX, strtoimax() */
 
64
                                   FD_CLOEXEC, open(), O_RDONLY,
 
65
                                   O_CLOEXEC, openat() */
 
66
#include <sys/wait.h>           /* waitpid(), WNOHANG, WIFEXITED(),
 
67
                                   WEXITSTATUS(), WIFSIGNALED(),
 
68
                                   WTERMSIG(), wait() */
 
69
#include <error.h>              /* error() */
 
70
#include <stdio.h>              /* FILE, fprintf(), fopen(),
 
71
                                   getline(), fclose(), EOF,
 
72
                                   asprintf(), stderr */
 
73
#include <dirent.h>             /* struct dirent, scandirat(),
 
74
                                   alphasort() */
 
75
#include <sys/stat.h>           /* struct stat, fstat(), S_ISDIR(),
 
76
                                   lstat(), S_ISREG() */
 
77
#include <sys/select.h>         /* fd_set, FD_ZERO(), FD_SETSIZE,
 
78
                                   FD_SET(), select(), FD_CLR(),
 
79
                                   FD_ISSET() */
 
80
#include <signal.h>             /* struct sigaction, SA_NOCLDSTOP,
 
81
                                   sigemptyset(), sigaddset(),
 
82
                                   SIGCHLD, sigprocmask(), SIG_BLOCK,
 
83
                                   SIG_UNBLOCK, kill(), SIGTERM */
71
84
#include <sysexits.h>           /* EX_OSERR, EX_USAGE, EX_IOERR,
72
85
                                   EX_CONFIG, EX_UNAVAILABLE, EX_OK */
 
86
#include <inttypes.h>           /* intmax_t, strtoimax(), PRIdMAX */
 
87
#include <fnmatch.h>            /* fnmatch(), FNM_FILE_NAME,
 
88
                                   FNM_PERIOD, FNM_NOMATCH */
73
89
 
74
90
#define BUFFER_SIZE 256
75
91
 
76
92
#define PDIR "/lib/mandos/plugins.d"
 
93
#define PHDIR "/lib/mandos/plugin-helpers"
77
94
#define AFILE "/conf/conf.d/mandos/plugin-runner.conf"
78
95
 
79
96
const char *argp_program_version = "plugin-runner " VERSION;
80
 
const char *argp_program_bug_address = "<mandos@fukt.bsnet.se>";
 
97
const char *argp_program_bug_address = "<mandos@recompile.se>";
81
98
 
82
99
typedef struct plugin{
83
100
  char *name;                   /* can be NULL or any plugin name */
103
120
 
104
121
/* Gets an existing plugin based on name,
105
122
   or if none is found, creates a new one */
 
123
__attribute__((warn_unused_result))
106
124
static plugin *getplugin(char *name){
107
125
  /* Check for existing plugin with that name */
108
126
  for(plugin *p = plugin_list; p != NULL; p = p->next){
169
187
}
170
188
 
171
189
/* Helper function for add_argument and add_environment */
 
190
__attribute__((nonnull, warn_unused_result))
172
191
static bool add_to_char_array(const char *new, char ***array,
173
192
                              int *len){
174
193
  /* Resize the pointed-to array to hold one more pointer */
 
194
  char **new_array = NULL;
175
195
  do {
176
 
    *array = realloc(*array, sizeof(char *)
177
 
                     * (size_t) ((*len) + 2));
178
 
  } while(*array == NULL and errno == EINTR);
 
196
#if defined(__GLIBC_PREREQ) and __GLIBC_PREREQ(2, 26)
 
197
    new_array = reallocarray(*array, (size_t)((*len) + 2),
 
198
                             sizeof(char *));
 
199
#else
 
200
    if(((size_t)((*len) + 2)) > (SIZE_MAX / sizeof(char *))){
 
201
      /* overflow */
 
202
      new_array = NULL;
 
203
      errno = ENOMEM;
 
204
    } else {
 
205
      new_array = realloc(*array, (size_t)((*len) + 2)
 
206
                          * sizeof(char *));
 
207
    }
 
208
#endif
 
209
  } while(new_array == NULL and errno == EINTR);
179
210
  /* Malloc check */
180
 
  if(*array == NULL){
 
211
  if(new_array == NULL){
181
212
    return false;
182
213
  }
 
214
  *array = new_array;
183
215
  /* Make a copy of the new string */
184
216
  char *copy;
185
217
  do {
197
229
}
198
230
 
199
231
/* Add to a plugin's argument vector */
 
232
__attribute__((nonnull(2), warn_unused_result))
200
233
static bool add_argument(plugin *p, const char *arg){
201
234
  if(p == NULL){
202
235
    return false;
205
238
}
206
239
 
207
240
/* Add to a plugin's environment */
 
241
__attribute__((nonnull(2), warn_unused_result))
208
242
static bool add_environment(plugin *p, const char *def, bool replace){
209
243
  if(p == NULL){
210
244
    return false;
212
246
  /* namelen = length of name of environment variable */
213
247
  size_t namelen = (size_t)(strchrnul(def, '=') - def);
214
248
  /* Search for this environment variable */
215
 
  for(char **e = p->environ; *e != NULL; e++){
216
 
    if(strncmp(*e, def, namelen + 1) == 0){
 
249
  for(char **envdef = p->environ; *envdef != NULL; envdef++){
 
250
    if(strncmp(*envdef, def, namelen + 1) == 0){
217
251
      /* It already exists */
218
252
      if(replace){
219
 
        char *new;
 
253
        char *new_envdef;
220
254
        do {
221
 
          new = realloc(*e, strlen(def) + 1);
222
 
        } while(new == NULL and errno == EINTR);
223
 
        if(new == NULL){
 
255
          new_envdef = realloc(*envdef, strlen(def) + 1);
 
256
        } while(new_envdef == NULL and errno == EINTR);
 
257
        if(new_envdef == NULL){
224
258
          return false;
225
259
        }
226
 
        *e = new;
227
 
        strcpy(*e, def);
 
260
        *envdef = new_envdef;
 
261
        strcpy(*envdef, def);
228
262
      }
229
263
      return true;
230
264
    }
232
266
  return add_to_char_array(def, &(p->environ), &(p->envc));
233
267
}
234
268
 
 
269
#ifndef O_CLOEXEC
235
270
/*
236
271
 * Based on the example in the GNU LibC manual chapter 13.13 "File
237
272
 * Descriptor Flags".
238
273
 | [[info:libc:Descriptor%20Flags][File Descriptor Flags]] |
239
274
 */
 
275
__attribute__((warn_unused_result))
240
276
static int set_cloexec_flag(int fd){
241
277
  int ret = (int)TEMP_FAILURE_RETRY(fcntl(fd, F_GETFD, 0));
242
278
  /* If reading the flags failed, return error indication now. */
247
283
  return (int)TEMP_FAILURE_RETRY(fcntl(fd, F_SETFD,
248
284
                                       ret | FD_CLOEXEC));
249
285
}
 
286
#endif  /* not O_CLOEXEC */
250
287
 
251
288
 
252
289
/* Mark processes as completed when they exit, and save their exit
266
303
        /* No child processes */
267
304
        break;
268
305
      }
269
 
      perror("waitpid");
 
306
      error(0, errno, "waitpid");
270
307
    }
271
308
    
272
309
    /* A child exited, find it in process_list */
284
321
}
285
322
 
286
323
/* Prints out a password to stdout */
 
324
__attribute__((nonnull, warn_unused_result))
287
325
static bool print_out_password(const char *buffer, size_t length){
288
326
  ssize_t ret;
289
327
  for(size_t written = 0; written < length; written += (size_t)ret){
297
335
}
298
336
 
299
337
/* Removes and free a plugin from the plugin list */
 
338
__attribute__((nonnull))
300
339
static void free_plugin(plugin *plugin_node){
301
340
  
302
 
  for(char **arg = plugin_node->argv; *arg != NULL; arg++){
 
341
  for(char **arg = (plugin_node->argv)+1; *arg != NULL; arg++){
303
342
    free(*arg);
304
343
  }
 
344
  free(plugin_node->name);
305
345
  free(plugin_node->argv);
306
346
  for(char **env = plugin_node->environ; *env != NULL; env++){
307
347
    free(*env);
334
374
 
335
375
int main(int argc, char *argv[]){
336
376
  char *plugindir = NULL;
 
377
  char *pluginhelperdir = NULL;
337
378
  char *argfile = NULL;
338
379
  FILE *conffp;
339
 
  size_t d_name_len;
340
 
  DIR *dir = NULL;
341
 
  struct dirent *dirst;
 
380
  struct dirent **direntries = NULL;
342
381
  struct stat st;
343
382
  fd_set rfds_all;
344
383
  int ret, maxfd = 0;
352
391
                                      .sa_flags = SA_NOCLDSTOP };
353
392
  char **custom_argv = NULL;
354
393
  int custom_argc = 0;
 
394
  int dir_fd = -1;
355
395
  
356
396
  /* Establish a signal handler */
357
397
  sigemptyset(&sigchld_action.sa_mask);
358
398
  ret = sigaddset(&sigchld_action.sa_mask, SIGCHLD);
359
399
  if(ret == -1){
360
 
    perror("sigaddset");
 
400
    error(0, errno, "sigaddset");
361
401
    exitstatus = EX_OSERR;
362
402
    goto fallback;
363
403
  }
364
404
  ret = sigaction(SIGCHLD, &sigchld_action, &old_sigchld_action);
365
405
  if(ret == -1){
366
 
    perror("sigaction");
 
406
    error(0, errno, "sigaction");
367
407
    exitstatus = EX_OSERR;
368
408
    goto fallback;
369
409
  }
402
442
      .doc = "Group ID the plugins will run as", .group = 3 },
403
443
    { .name = "debug", .key = 132,
404
444
      .doc = "Debug mode", .group = 4 },
 
445
    { .name = "plugin-helper-dir", .key = 133,
 
446
      .arg = "DIRECTORY",
 
447
      .doc = "Specify a different plugin helper directory",
 
448
      .group = 2 },
405
449
    /*
406
450
     * These reproduce what we would get without ARGP_NO_HELP
407
451
     */
414
458
    { .name = NULL }
415
459
  };
416
460
  
 
461
  __attribute__((nonnull(3)))
417
462
  error_t parse_opt(int key, char *arg, struct argp_state *state){
418
463
    errno = 0;
419
464
    switch(key){
420
465
      char *tmp;
421
 
      intmax_t tmpmax;
 
466
      intmax_t tmp_id;
422
467
    case 'g':                   /* --global-options */
423
468
      {
424
469
        char *plugin_option;
427
472
            break;
428
473
          }
429
474
        }
 
475
        errno = 0;
430
476
      }
431
477
      break;
432
478
    case 'G':                   /* --global-env */
433
 
      add_environment(getplugin(NULL), arg, true);
 
479
      if(add_environment(getplugin(NULL), arg, true)){
 
480
        errno = 0;
 
481
      }
434
482
      break;
435
483
    case 'o':                   /* --options-for */
436
484
      {
453
501
            break;
454
502
          }
455
503
        }
 
504
        errno = 0;
456
505
      }
457
506
      break;
458
507
    case 'E':                   /* --env-for */
470
519
          errno = EINVAL;
471
520
          break;
472
521
        }
473
 
        add_environment(getplugin(arg), envdef, true);
 
522
        if(add_environment(getplugin(arg), envdef, true)){
 
523
          errno = 0;
 
524
        }
474
525
      }
475
526
      break;
476
527
    case 'd':                   /* --disable */
478
529
        plugin *p = getplugin(arg);
479
530
        if(p != NULL){
480
531
          p->disabled = true;
 
532
          errno = 0;
481
533
        }
482
534
      }
483
535
      break;
486
538
        plugin *p = getplugin(arg);
487
539
        if(p != NULL){
488
540
          p->disabled = false;
 
541
          errno = 0;
489
542
        }
490
543
      }
491
544
      break;
492
545
    case 128:                   /* --plugin-dir */
493
546
      free(plugindir);
494
547
      plugindir = strdup(arg);
 
548
      if(plugindir != NULL){
 
549
        errno = 0;
 
550
      }
495
551
      break;
496
552
    case 129:                   /* --config-file */
497
553
      /* This is already done by parse_opt_config_file() */
498
554
      break;
499
555
    case 130:                   /* --userid */
500
 
      tmpmax = strtoimax(arg, &tmp, 10);
 
556
      tmp_id = strtoimax(arg, &tmp, 10);
501
557
      if(errno != 0 or tmp == arg or *tmp != '\0'
502
 
         or tmpmax != (uid_t)tmpmax){
 
558
         or tmp_id != (uid_t)tmp_id){
503
559
        argp_error(state, "Bad user ID number: \"%s\", using %"
504
560
                   PRIdMAX, arg, (intmax_t)uid);
505
561
        break;
506
562
      }
507
 
      uid = (uid_t)tmpmax;
 
563
      uid = (uid_t)tmp_id;
 
564
      errno = 0;
508
565
      break;
509
566
    case 131:                   /* --groupid */
510
 
      tmpmax = strtoimax(arg, &tmp, 10);
 
567
      tmp_id = strtoimax(arg, &tmp, 10);
511
568
      if(errno != 0 or tmp == arg or *tmp != '\0'
512
 
         or tmpmax != (gid_t)tmpmax){
 
569
         or tmp_id != (gid_t)tmp_id){
513
570
        argp_error(state, "Bad group ID number: \"%s\", using %"
514
571
                   PRIdMAX, arg, (intmax_t)gid);
515
572
        break;
516
573
      }
517
 
      gid = (gid_t)tmpmax;
 
574
      gid = (gid_t)tmp_id;
 
575
      errno = 0;
518
576
      break;
519
577
    case 132:                   /* --debug */
520
578
      debug = true;
521
579
      break;
 
580
    case 133:                   /* --plugin-helper-dir */
 
581
      free(pluginhelperdir);
 
582
      pluginhelperdir = strdup(arg);
 
583
      if(pluginhelperdir != NULL){
 
584
        errno = 0;
 
585
      }
 
586
      break;
522
587
      /*
523
588
       * These reproduce what we would get without ARGP_NO_HELP
524
589
       */
525
590
    case '?':                   /* --help */
526
591
      state->flags &= ~(unsigned int)ARGP_NO_EXIT; /* force exit */
527
592
      argp_state_help(state, state->out_stream, ARGP_HELP_STD_HELP);
 
593
      __builtin_unreachable();
528
594
    case -3:                    /* --usage */
529
595
      state->flags &= ~(unsigned int)ARGP_NO_EXIT; /* force exit */
530
596
      argp_state_help(state, state->out_stream,
531
597
                      ARGP_HELP_USAGE | ARGP_HELP_EXIT_OK);
 
598
      __builtin_unreachable();
532
599
    case 'V':                   /* --version */
533
600
      fprintf(state->out_stream, "%s\n", argp_program_version);
534
601
      exit(EXIT_SUCCESS);
544
611
      if(arg[0] == '\0'){
545
612
        break;
546
613
      }
 
614
#if __GNUC__ >= 7
 
615
      __attribute__((fallthrough));
 
616
#else
 
617
          /* FALLTHROUGH */
 
618
#endif
547
619
    default:
548
620
      return ARGP_ERR_UNKNOWN;
549
621
    }
568
640
    case 129:                   /* --config-file */
569
641
      free(argfile);
570
642
      argfile = strdup(arg);
 
643
      if(argfile != NULL){
 
644
        errno = 0;
 
645
      }
571
646
      break;
572
647
    case 130:                   /* --userid */
573
648
    case 131:                   /* --groupid */
574
649
    case 132:                   /* --debug */
 
650
    case 133:                   /* --plugin-helper-dir */
575
651
    case '?':                   /* --help */
576
652
    case -3:                    /* --usage */
577
653
    case 'V':                   /* --version */
599
675
  case ENOMEM:
600
676
  default:
601
677
    errno = ret;
602
 
    perror("argp_parse");
 
678
    error(0, errno, "argp_parse");
603
679
    exitstatus = EX_OSERR;
604
680
    goto fallback;
605
681
  case EINVAL:
626
702
    custom_argc = 1;
627
703
    custom_argv = malloc(sizeof(char*) * 2);
628
704
    if(custom_argv == NULL){
629
 
      perror("malloc");
 
705
      error(0, errno, "malloc");
630
706
      exitstatus = EX_OSERR;
631
707
      goto fallback;
632
708
    }
649
725
        }
650
726
        new_arg = strdup(p);
651
727
        if(new_arg == NULL){
652
 
          perror("strdup");
 
728
          error(0, errno, "strdup");
653
729
          exitstatus = EX_OSERR;
654
730
          free(org_line);
655
731
          goto fallback;
656
732
        }
657
733
        
658
734
        custom_argc += 1;
659
 
        custom_argv = realloc(custom_argv, sizeof(char *)
660
 
                              * ((unsigned int) custom_argc + 1));
661
 
        if(custom_argv == NULL){
662
 
          perror("realloc");
663
 
          exitstatus = EX_OSERR;
664
 
          free(org_line);
665
 
          goto fallback;
 
735
        {
 
736
#if defined(__GLIBC_PREREQ) and __GLIBC_PREREQ(2, 26)
 
737
          char **new_argv = reallocarray(custom_argv,
 
738
                                         (size_t)custom_argc + 1,
 
739
                                         sizeof(char *));
 
740
#else
 
741
          char **new_argv = NULL;
 
742
          if(((size_t)custom_argc + 1) > (SIZE_MAX / sizeof(char *))){
 
743
            /* overflow */
 
744
            errno = ENOMEM;
 
745
          } else {
 
746
            new_argv = realloc(custom_argv, ((size_t)custom_argc + 1)
 
747
                               * sizeof(char *));
 
748
          }
 
749
#endif
 
750
          if(new_argv == NULL){
 
751
            error(0, errno, "reallocarray");
 
752
            exitstatus = EX_OSERR;
 
753
            free(new_arg);
 
754
            free(org_line);
 
755
            goto fallback;
 
756
          } else {
 
757
            custom_argv = new_argv;
 
758
          }
666
759
        }
667
760
        custom_argv[custom_argc-1] = new_arg;
668
761
        custom_argv[custom_argc] = NULL;
672
765
      ret = fclose(conffp);
673
766
    } while(ret == EOF and errno == EINTR);
674
767
    if(ret == EOF){
675
 
      perror("fclose");
 
768
      error(0, errno, "fclose");
676
769
      exitstatus = EX_IOERR;
677
770
      goto fallback;
678
771
    }
681
774
    /* Check for harmful errors and go to fallback. Other errors might
682
775
       not affect opening plugins */
683
776
    if(errno == EMFILE or errno == ENFILE or errno == ENOMEM){
684
 
      perror("fopen");
685
 
      exitstatus = EX_IOERR;
 
777
      error(0, errno, "fopen");
 
778
      exitstatus = EX_OSERR;
686
779
      goto fallback;
687
780
    }
688
781
  }
698
791
    case ENOMEM:
699
792
    default:
700
793
      errno = ret;
701
 
      perror("argp_parse");
 
794
      error(0, errno, "argp_parse");
702
795
      exitstatus = EX_OSERR;
703
796
      goto fallback;
704
797
    case EINVAL:
718
811
  case ENOMEM:
719
812
  default:
720
813
    errno = ret;
721
 
    perror("argp_parse");
 
814
    error(0, errno, "argp_parse");
722
815
    exitstatus = EX_OSERR;
723
816
    goto fallback;
724
817
  case EINVAL:
726
819
    goto fallback;
727
820
  }
728
821
  
 
822
  {
 
823
    char *pluginhelperenv;
 
824
    bool bret = true;
 
825
    ret = asprintf(&pluginhelperenv, "MANDOSPLUGINHELPERDIR=%s",
 
826
                   pluginhelperdir != NULL ? pluginhelperdir : PHDIR);
 
827
    if(ret != -1){
 
828
      bret = add_environment(getplugin(NULL), pluginhelperenv, true);
 
829
    }
 
830
    if(ret == -1 or not bret){
 
831
      error(0, errno, "Failed to set MANDOSPLUGINHELPERDIR"
 
832
            " environment variable to \"%s\" for all plugins\n",
 
833
            pluginhelperdir != NULL ? pluginhelperdir : PHDIR);
 
834
    }
 
835
    if(ret != -1){
 
836
      free(pluginhelperenv);
 
837
    }
 
838
  }
 
839
  
729
840
  if(debug){
730
 
    for(plugin *p = plugin_list; p != NULL; p=p->next){
 
841
    for(plugin *p = plugin_list; p != NULL; p = p->next){
731
842
      fprintf(stderr, "Plugin: %s has %d arguments\n",
732
843
              p->name ? p->name : "Global", p->argc - 1);
733
844
      for(char **a = p->argv; *a != NULL; a++){
740
851
    }
741
852
  }
742
853
  
743
 
  /* Strip permissions down to nobody */
744
 
  setgid(gid);
 
854
  if(getuid() == 0){
 
855
    /* Work around Debian bug #633582:
 
856
       <https://bugs.debian.org/633582> */
 
857
    int plugindir_fd = open(/* plugindir or */ PDIR, O_RDONLY);
 
858
    if(plugindir_fd == -1){
 
859
      if(errno != ENOENT){
 
860
        error(0, errno, "open(\"" PDIR "\")");
 
861
      }
 
862
    } else {
 
863
      ret = (int)TEMP_FAILURE_RETRY(fstat(plugindir_fd, &st));
 
864
      if(ret == -1){
 
865
        error(0, errno, "fstat");
 
866
      } else {
 
867
        if(S_ISDIR(st.st_mode) and st.st_uid == 0 and st.st_gid == 0){
 
868
          ret = fchown(plugindir_fd, uid, gid);
 
869
          if(ret == -1){
 
870
            error(0, errno, "fchown");
 
871
          }
 
872
        }
 
873
      }
 
874
      close(plugindir_fd);
 
875
    }
 
876
 
 
877
    /* Work around Debian bug #981302
 
878
       <https://bugs.debian.org/981302> */
 
879
    if(lstat("/dev/fd", &st) != 0 and errno == ENOENT){
 
880
      ret = symlink("/proc/self/fd", "/dev/fd");
 
881
      if(ret == -1){
 
882
        error(0, errno, "Failed to create /dev/fd symlink");
 
883
      }
 
884
    }
 
885
  }
 
886
  
 
887
  /* Lower permissions */
 
888
  ret = setgid(gid);
745
889
  if(ret == -1){
746
 
    perror("setgid");
 
890
    error(0, errno, "setgid");
747
891
  }
748
892
  ret = setuid(uid);
749
893
  if(ret == -1){
750
 
    perror("setuid");
 
894
    error(0, errno, "setuid");
751
895
  }
752
896
  
753
897
  /* Open plugin directory with close_on_exec flag */
754
898
  {
755
 
    int dir_fd = -1;
756
 
    if(plugindir == NULL){
757
 
      dir_fd = open(PDIR, O_RDONLY |
758
 
#ifdef O_CLOEXEC
759
 
                    O_CLOEXEC
760
 
#else  /* not O_CLOEXEC */
761
 
                    0
762
 
#endif  /* not O_CLOEXEC */
763
 
                    );
764
 
    } else {
765
 
      dir_fd = open(plugindir, O_RDONLY |
766
 
#ifdef O_CLOEXEC
767
 
                    O_CLOEXEC
768
 
#else  /* not O_CLOEXEC */
769
 
                    0
770
 
#endif  /* not O_CLOEXEC */
771
 
                    );
772
 
    }
 
899
    dir_fd = open(plugindir != NULL ? plugindir : PDIR, O_RDONLY |
 
900
#ifdef O_CLOEXEC
 
901
                  O_CLOEXEC
 
902
#else  /* not O_CLOEXEC */
 
903
                  0
 
904
#endif  /* not O_CLOEXEC */
 
905
                  );
773
906
    if(dir_fd == -1){
774
 
      perror("Could not open plugin dir");
 
907
      error(0, errno, "Could not open plugin dir");
775
908
      exitstatus = EX_UNAVAILABLE;
776
909
      goto fallback;
777
910
    }
780
913
  /* Set the FD_CLOEXEC flag on the directory */
781
914
    ret = set_cloexec_flag(dir_fd);
782
915
    if(ret < 0){
783
 
      perror("set_cloexec_flag");
784
 
      TEMP_FAILURE_RETRY(close(dir_fd));
 
916
      error(0, errno, "set_cloexec_flag");
785
917
      exitstatus = EX_OSERR;
786
918
      goto fallback;
787
919
    }
788
920
#endif  /* O_CLOEXEC */
789
 
    
790
 
    dir = fdopendir(dir_fd);
791
 
    if(dir == NULL){
792
 
      perror("Could not open plugin dir");
793
 
      TEMP_FAILURE_RETRY(close(dir_fd));
794
 
      exitstatus = EX_OSERR;
795
 
      goto fallback;
 
921
  }
 
922
  
 
923
  int good_name(const struct dirent * const dirent){
 
924
    const char * const patterns[] = { ".*", "#*#", "*~", "*.dpkg-new",
 
925
                                      "*.dpkg-old", "*.dpkg-bak",
 
926
                                      "*.dpkg-divert", NULL };
 
927
#ifdef __GNUC__
 
928
#pragma GCC diagnostic push
 
929
#pragma GCC diagnostic ignored "-Wcast-qual"
 
930
#endif
 
931
    for(const char **pat = (const char **)patterns;
 
932
        *pat != NULL; pat++){
 
933
#ifdef __GNUC__
 
934
#pragma GCC diagnostic pop
 
935
#endif
 
936
      if(fnmatch(*pat, dirent->d_name, FNM_FILE_NAME | FNM_PERIOD)
 
937
         != FNM_NOMATCH){
 
938
        if(debug){
 
939
            fprintf(stderr, "Ignoring plugin dir entry \"%s\""
 
940
                    " matching pattern %s\n", dirent->d_name, *pat);
 
941
        }
 
942
        return 0;
 
943
      }
796
944
    }
 
945
    return 1;
 
946
  }
 
947
  
 
948
  int numplugins = scandirat(dir_fd, ".", &direntries, good_name,
 
949
                             alphasort);
 
950
  if(numplugins == -1){
 
951
    error(0, errno, "Could not scan plugin dir");
 
952
    direntries = NULL;
 
953
    exitstatus = EX_OSERR;
 
954
    goto fallback;
797
955
  }
798
956
  
799
957
  FD_ZERO(&rfds_all);
800
958
  
801
959
  /* Read and execute any executable in the plugin directory*/
802
 
  while(true){
803
 
    do {
804
 
      dirst = readdir(dir);
805
 
    } while(dirst == NULL and errno == EINTR);
806
 
    
807
 
    /* All directory entries have been processed */
808
 
    if(dirst == NULL){
809
 
      if(errno == EBADF){
810
 
        perror("readdir");
811
 
        exitstatus = EX_IOERR;
812
 
        goto fallback;
813
 
      }
814
 
      break;
815
 
    }
816
 
    
817
 
    d_name_len = strlen(dirst->d_name);
818
 
    
819
 
    /* Ignore dotfiles, backup files and other junk */
820
 
    {
821
 
      bool bad_name = false;
822
 
      
823
 
      const char const *bad_prefixes[] = { ".", "#", NULL };
824
 
      
825
 
      const char const *bad_suffixes[] = { "~", "#", ".dpkg-new",
826
 
                                           ".dpkg-old",
827
 
                                           ".dpkg-bak",
828
 
                                           ".dpkg-divert", NULL };
829
 
      for(const char **pre = bad_prefixes; *pre != NULL; pre++){
830
 
        size_t pre_len = strlen(*pre);
831
 
        if((d_name_len >= pre_len)
832
 
           and strncmp((dirst->d_name), *pre, pre_len) == 0){
833
 
          if(debug){
834
 
            fprintf(stderr, "Ignoring plugin dir entry \"%s\""
835
 
                    " with bad prefix %s\n", dirst->d_name, *pre);
836
 
          }
837
 
          bad_name = true;
838
 
          break;
839
 
        }
840
 
      }
841
 
      if(bad_name){
842
 
        continue;
843
 
      }
844
 
      for(const char **suf = bad_suffixes; *suf != NULL; suf++){
845
 
        size_t suf_len = strlen(*suf);
846
 
        if((d_name_len >= suf_len)
847
 
           and (strcmp((dirst->d_name)+d_name_len-suf_len, *suf)
848
 
                == 0)){
849
 
          if(debug){
850
 
            fprintf(stderr, "Ignoring plugin dir entry \"%s\""
851
 
                    " with bad suffix %s\n", dirst->d_name, *suf);
852
 
          }
853
 
          bad_name = true;
854
 
          break;
855
 
        }
856
 
      }
857
 
      
858
 
      if(bad_name){
859
 
        continue;
860
 
      }
861
 
    }
862
 
    
863
 
    char *filename;
864
 
    if(plugindir == NULL){
865
 
      ret = (int)TEMP_FAILURE_RETRY(asprintf(&filename, PDIR "/%s",
866
 
                                             dirst->d_name));
867
 
    } else {
868
 
      ret = (int)TEMP_FAILURE_RETRY(asprintf(&filename, "%s/%s",
869
 
                                             plugindir,
870
 
                                             dirst->d_name));
871
 
    }
872
 
    if(ret < 0){
873
 
      perror("asprintf");
 
960
  for(int i = 0; i < numplugins; i++){
 
961
    
 
962
    int plugin_fd = openat(dir_fd, direntries[i]->d_name, O_RDONLY);
 
963
    if(plugin_fd == -1){
 
964
      error(0, errno, "Could not open plugin");
 
965
      free(direntries[i]);
874
966
      continue;
875
967
    }
876
 
    
877
 
    ret = (int)TEMP_FAILURE_RETRY(stat(filename, &st));
 
968
    ret = (int)TEMP_FAILURE_RETRY(fstat(plugin_fd, &st));
878
969
    if(ret == -1){
879
 
      perror("stat");
880
 
      free(filename);
 
970
      error(0, errno, "stat");
 
971
      close(plugin_fd);
 
972
      free(direntries[i]);
881
973
      continue;
882
974
    }
883
975
    
884
976
    /* Ignore non-executable files */
885
977
    if(not S_ISREG(st.st_mode)
886
 
       or (TEMP_FAILURE_RETRY(access(filename, X_OK)) != 0)){
 
978
       or (TEMP_FAILURE_RETRY(faccessat(dir_fd, direntries[i]->d_name,
 
979
                                        X_OK, 0)) != 0)){
887
980
      if(debug){
888
 
        fprintf(stderr, "Ignoring plugin dir entry \"%s\""
889
 
                " with bad type or mode\n", filename);
 
981
        fprintf(stderr, "Ignoring plugin dir entry \"%s/%s\""
 
982
                " with bad type or mode\n",
 
983
                plugindir != NULL ? plugindir : PDIR,
 
984
                direntries[i]->d_name);
890
985
      }
891
 
      free(filename);
 
986
      close(plugin_fd);
 
987
      free(direntries[i]);
892
988
      continue;
893
989
    }
894
990
    
895
 
    plugin *p = getplugin(dirst->d_name);
 
991
    plugin *p = getplugin(direntries[i]->d_name);
896
992
    if(p == NULL){
897
 
      perror("getplugin");
898
 
      free(filename);
 
993
      error(0, errno, "getplugin");
 
994
      close(plugin_fd);
 
995
      free(direntries[i]);
899
996
      continue;
900
997
    }
901
998
    if(p->disabled){
902
999
      if(debug){
903
1000
        fprintf(stderr, "Ignoring disabled plugin \"%s\"\n",
904
 
                dirst->d_name);
 
1001
                direntries[i]->d_name);
905
1002
      }
906
 
      free(filename);
 
1003
      close(plugin_fd);
 
1004
      free(direntries[i]);
907
1005
      continue;
908
1006
    }
909
1007
    {
912
1010
      if(g != NULL){
913
1011
        for(char **a = g->argv + 1; *a != NULL; a++){
914
1012
          if(not add_argument(p, *a)){
915
 
            perror("add_argument");
 
1013
            error(0, errno, "add_argument");
916
1014
          }
917
1015
        }
918
1016
        /* Add global environment variables */
919
1017
        for(char **e = g->environ; *e != NULL; e++){
920
1018
          if(not add_environment(p, *e, false)){
921
 
            perror("add_environment");
 
1019
            error(0, errno, "add_environment");
922
1020
          }
923
1021
        }
924
1022
      }
925
1023
    }
926
 
    /* If this plugin has any environment variables, we will call
927
 
       using execve and need to duplicate the environment from this
928
 
       process, too. */
 
1024
    /* If this plugin has any environment variables, we need to
 
1025
       duplicate the environment from this process, too. */
929
1026
    if(p->environ[0] != NULL){
930
1027
      for(char **e = environ; *e != NULL; e++){
931
1028
        if(not add_environment(p, *e, false)){
932
 
          perror("add_environment");
 
1029
          error(0, errno, "add_environment");
933
1030
        }
934
1031
      }
935
1032
    }
936
1033
    
937
1034
    int pipefd[2];
 
1035
#ifndef O_CLOEXEC
938
1036
    ret = (int)TEMP_FAILURE_RETRY(pipe(pipefd));
 
1037
#else  /* O_CLOEXEC */
 
1038
    ret = (int)TEMP_FAILURE_RETRY(pipe2(pipefd, O_CLOEXEC));
 
1039
#endif  /* O_CLOEXEC */
939
1040
    if(ret == -1){
940
 
      perror("pipe");
941
 
      exitstatus = EX_OSERR;
942
 
      goto fallback;
943
 
    }
 
1041
      error(0, errno, "pipe");
 
1042
      exitstatus = EX_OSERR;
 
1043
      free(direntries[i]);
 
1044
      goto fallback;
 
1045
    }
 
1046
    if(pipefd[0] >= FD_SETSIZE){
 
1047
      fprintf(stderr, "pipe()[0] (%d) >= FD_SETSIZE (%d)", pipefd[0],
 
1048
              FD_SETSIZE);
 
1049
      close(pipefd[0]);
 
1050
      close(pipefd[1]);
 
1051
      exitstatus = EX_OSERR;
 
1052
      free(direntries[i]);
 
1053
      goto fallback;
 
1054
    }
 
1055
#ifndef O_CLOEXEC
944
1056
    /* Ask OS to automatic close the pipe on exec */
945
1057
    ret = set_cloexec_flag(pipefd[0]);
946
1058
    if(ret < 0){
947
 
      perror("set_cloexec_flag");
 
1059
      error(0, errno, "set_cloexec_flag");
 
1060
      close(pipefd[0]);
 
1061
      close(pipefd[1]);
948
1062
      exitstatus = EX_OSERR;
 
1063
      free(direntries[i]);
949
1064
      goto fallback;
950
1065
    }
951
1066
    ret = set_cloexec_flag(pipefd[1]);
952
1067
    if(ret < 0){
953
 
      perror("set_cloexec_flag");
 
1068
      error(0, errno, "set_cloexec_flag");
 
1069
      close(pipefd[0]);
 
1070
      close(pipefd[1]);
954
1071
      exitstatus = EX_OSERR;
 
1072
      free(direntries[i]);
955
1073
      goto fallback;
956
1074
    }
 
1075
#endif  /* not O_CLOEXEC */
957
1076
    /* Block SIGCHLD until process is safely in process list */
958
1077
    ret = (int)TEMP_FAILURE_RETRY(sigprocmask(SIG_BLOCK,
959
1078
                                              &sigchld_action.sa_mask,
960
1079
                                              NULL));
961
1080
    if(ret < 0){
962
 
      perror("sigprocmask");
 
1081
      error(0, errno, "sigprocmask");
963
1082
      exitstatus = EX_OSERR;
 
1083
      free(direntries[i]);
964
1084
      goto fallback;
965
1085
    }
966
1086
    /* Starting a new process to be watched */
969
1089
      pid = fork();
970
1090
    } while(pid == -1 and errno == EINTR);
971
1091
    if(pid == -1){
972
 
      perror("fork");
 
1092
      error(0, errno, "fork");
 
1093
      TEMP_FAILURE_RETRY(sigprocmask(SIG_UNBLOCK,
 
1094
                                     &sigchld_action.sa_mask, NULL));
 
1095
      close(pipefd[0]);
 
1096
      close(pipefd[1]);
973
1097
      exitstatus = EX_OSERR;
 
1098
      free(direntries[i]);
974
1099
      goto fallback;
975
1100
    }
976
1101
    if(pid == 0){
977
1102
      /* this is the child process */
978
1103
      ret = sigaction(SIGCHLD, &old_sigchld_action, NULL);
979
1104
      if(ret < 0){
980
 
        perror("sigaction");
 
1105
        error(0, errno, "sigaction");
981
1106
        _exit(EX_OSERR);
982
1107
      }
983
1108
      ret = sigprocmask(SIG_UNBLOCK, &sigchld_action.sa_mask, NULL);
984
1109
      if(ret < 0){
985
 
        perror("sigprocmask");
 
1110
        error(0, errno, "sigprocmask");
986
1111
        _exit(EX_OSERR);
987
1112
      }
988
1113
      
989
1114
      ret = dup2(pipefd[1], STDOUT_FILENO); /* replace our stdout */
990
1115
      if(ret == -1){
991
 
        perror("dup2");
 
1116
        error(0, errno, "dup2");
992
1117
        _exit(EX_OSERR);
993
1118
      }
994
1119
      
995
 
      if(dirfd(dir) < 0){
996
 
        /* If dir has no file descriptor, we could not set FD_CLOEXEC
997
 
           above and must now close it manually here. */
998
 
        closedir(dir);
999
 
      }
1000
 
      if(p->environ[0] == NULL){
1001
 
        if(execv(filename, p->argv) < 0){
1002
 
          perror("execv");
1003
 
          _exit(EX_OSERR);
1004
 
        }
1005
 
      } else {
1006
 
        if(execve(filename, p->argv, p->environ) < 0){
1007
 
          perror("execve");
1008
 
          _exit(EX_OSERR);
1009
 
        }
 
1120
      if(fexecve(plugin_fd, p->argv,
 
1121
                (p->environ[0] != NULL) ? p->environ : environ) < 0){
 
1122
        error(0, errno, "fexecve for %s/%s",
 
1123
              plugindir != NULL ? plugindir : PDIR,
 
1124
              direntries[i]->d_name);
 
1125
        _exit(EX_OSERR);
1010
1126
      }
1011
1127
      /* no return */
1012
1128
    }
1013
1129
    /* Parent process */
1014
 
    TEMP_FAILURE_RETRY(close(pipefd[1])); /* Close unused write end of
1015
 
                                             pipe */
1016
 
    free(filename);
1017
 
    plugin *new_plugin = getplugin(dirst->d_name);
 
1130
    close(pipefd[1]);           /* Close unused write end of pipe */
 
1131
    close(plugin_fd);
 
1132
    plugin *new_plugin = getplugin(direntries[i]->d_name);
1018
1133
    if(new_plugin == NULL){
1019
 
      perror("getplugin");
 
1134
      error(0, errno, "getplugin");
1020
1135
      ret = (int)(TEMP_FAILURE_RETRY
1021
1136
                  (sigprocmask(SIG_UNBLOCK, &sigchld_action.sa_mask,
1022
1137
                               NULL)));
1023
1138
      if(ret < 0){
1024
 
        perror("sigprocmask");
 
1139
        error(0, errno, "sigprocmask");
1025
1140
      }
1026
1141
      exitstatus = EX_OSERR;
 
1142
      free(direntries[i]);
1027
1143
      goto fallback;
1028
1144
    }
 
1145
    free(direntries[i]);
1029
1146
    
1030
1147
    new_plugin->pid = pid;
1031
1148
    new_plugin->fd = pipefd[0];
1032
 
    
 
1149
 
 
1150
    if(debug){
 
1151
      fprintf(stderr, "Plugin %s started (PID %" PRIdMAX ")\n",
 
1152
              new_plugin->name, (intmax_t) (new_plugin->pid));
 
1153
    }
 
1154
 
1033
1155
    /* Unblock SIGCHLD so signal handler can be run if this process
1034
1156
       has already completed */
1035
1157
    ret = (int)TEMP_FAILURE_RETRY(sigprocmask(SIG_UNBLOCK,
1036
1158
                                              &sigchld_action.sa_mask,
1037
1159
                                              NULL));
1038
1160
    if(ret < 0){
1039
 
      perror("sigprocmask");
 
1161
      error(0, errno, "sigprocmask");
1040
1162
      exitstatus = EX_OSERR;
1041
1163
      goto fallback;
1042
1164
    }
1043
1165
    
1044
 
    FD_SET(new_plugin->fd, &rfds_all); /* Spurious warning from
1045
 
                                          -Wconversion */
 
1166
    FD_SET(new_plugin->fd, &rfds_all);
1046
1167
    
1047
1168
    if(maxfd < new_plugin->fd){
1048
1169
      maxfd = new_plugin->fd;
1049
1170
    }
1050
1171
  }
1051
1172
  
1052
 
  TEMP_FAILURE_RETRY(closedir(dir));
1053
 
  dir = NULL;
 
1173
  free(direntries);
 
1174
  direntries = NULL;
 
1175
  close(dir_fd);
 
1176
  dir_fd = -1;
1054
1177
  free_plugin(getplugin(NULL));
1055
1178
  
1056
1179
  for(plugin *p = plugin_list; p != NULL; p = p->next){
1069
1192
    fd_set rfds = rfds_all;
1070
1193
    int select_ret = select(maxfd+1, &rfds, NULL, NULL, NULL);
1071
1194
    if(select_ret == -1 and errno != EINTR){
1072
 
      perror("select");
 
1195
      error(0, errno, "select");
1073
1196
      exitstatus = EX_OSERR;
1074
1197
      goto fallback;
1075
1198
    }
1095
1218
                      (intmax_t) (proc->pid),
1096
1219
                      WTERMSIG(proc->status),
1097
1220
                      strsignal(WTERMSIG(proc->status)));
1098
 
            } else if(WCOREDUMP(proc->status)){
1099
 
              fprintf(stderr, "Plugin %s [%" PRIdMAX "] dumped"
1100
 
                      " core\n", proc->name, (intmax_t) (proc->pid));
1101
1221
            }
1102
1222
          }
1103
1223
          
1104
1224
          /* Remove the plugin */
1105
 
          FD_CLR(proc->fd, &rfds_all); /* Spurious warning from
1106
 
                                          -Wconversion */
 
1225
          FD_CLR(proc->fd, &rfds_all);
1107
1226
          
1108
1227
          /* Block signal while modifying process_list */
1109
1228
          ret = (int)TEMP_FAILURE_RETRY(sigprocmask
1111
1230
                                         &sigchld_action.sa_mask,
1112
1231
                                         NULL));
1113
1232
          if(ret < 0){
1114
 
            perror("sigprocmask");
 
1233
            error(0, errno, "sigprocmask");
1115
1234
            exitstatus = EX_OSERR;
1116
1235
            goto fallback;
1117
1236
          }
1125
1244
                      (sigprocmask(SIG_UNBLOCK,
1126
1245
                                   &sigchld_action.sa_mask, NULL)));
1127
1246
          if(ret < 0){
1128
 
            perror("sigprocmask");
 
1247
            error(0, errno, "sigprocmask");
1129
1248
            exitstatus = EX_OSERR;
1130
1249
            goto fallback;
1131
1250
          }
1142
1261
        bool bret = print_out_password(proc->buffer,
1143
1262
                                       proc->buffer_length);
1144
1263
        if(not bret){
1145
 
          perror("print_out_password");
 
1264
          error(0, errno, "print_out_password");
1146
1265
          exitstatus = EX_IOERR;
1147
1266
        }
1148
1267
        goto fallback;
1149
1268
      }
1150
1269
      
1151
1270
      /* This process has not completed.  Does it have any output? */
1152
 
      if(proc->eof or not FD_ISSET(proc->fd, &rfds)){ /* Spurious
1153
 
                                                         warning from
1154
 
                                                         -Wconversion */
 
1271
      if(proc->eof or not FD_ISSET(proc->fd, &rfds)){
1155
1272
        /* This process had nothing to say at this time */
1156
1273
        proc = proc->next;
1157
1274
        continue;
1158
1275
      }
1159
1276
      /* Before reading, make the process' data buffer large enough */
1160
1277
      if(proc->buffer_length + BUFFER_SIZE > proc->buffer_size){
1161
 
        proc->buffer = realloc(proc->buffer, proc->buffer_size
1162
 
                               + (size_t) BUFFER_SIZE);
1163
 
        if(proc->buffer == NULL){
1164
 
          perror("malloc");
 
1278
        char *new_buffer = realloc(proc->buffer, proc->buffer_size
 
1279
                                   + (size_t) BUFFER_SIZE);
 
1280
        if(new_buffer == NULL){
 
1281
          error(0, errno, "malloc");
1165
1282
          exitstatus = EX_OSERR;
1166
1283
          goto fallback;
1167
1284
        }
 
1285
        proc->buffer = new_buffer;
1168
1286
        proc->buffer_size += BUFFER_SIZE;
1169
1287
      }
1170
1288
      /* Read from the process */
1204
1322
    }
1205
1323
    bret = print_out_password(passwordbuffer, len);
1206
1324
    if(not bret){
1207
 
      perror("print_out_password");
 
1325
      error(0, errno, "print_out_password");
1208
1326
      exitstatus = EX_IOERR;
1209
1327
    }
1210
1328
  }
1212
1330
  /* Restore old signal handler */
1213
1331
  ret = sigaction(SIGCHLD, &old_sigchld_action, NULL);
1214
1332
  if(ret == -1){
1215
 
    perror("sigaction");
 
1333
    error(0, errno, "sigaction");
1216
1334
    exitstatus = EX_OSERR;
1217
1335
  }
1218
1336
  
1223
1341
    free(custom_argv);
1224
1342
  }
1225
1343
  
1226
 
  if(dir != NULL){
1227
 
    closedir(dir);
 
1344
  free(direntries);
 
1345
  
 
1346
  if(dir_fd != -1){
 
1347
    close(dir_fd);
1228
1348
  }
1229
1349
  
1230
1350
  /* Kill the processes */
1234
1354
      ret = kill(p->pid, SIGTERM);
1235
1355
      if(ret == -1 and errno != ESRCH){
1236
1356
        /* Set-uid proccesses might not get closed */
1237
 
        perror("kill");
 
1357
        error(0, errno, "kill");
1238
1358
      }
1239
1359
    }
1240
1360
  }
1244
1364
    ret = wait(NULL);
1245
1365
  } while(ret >= 0);
1246
1366
  if(errno != ECHILD){
1247
 
    perror("wait");
 
1367
    error(0, errno, "wait");
1248
1368
  }
1249
1369
  
1250
1370
  free_plugin_list();
1251
1371
  
1252
1372
  free(plugindir);
 
1373
  free(pluginhelperdir);
1253
1374
  free(argfile);
1254
1375
  
1255
1376
  return exitstatus;