/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-03-17 20:40:55 UTC
  • mto: (237.7.594 trunk)
  • mto: This revision was merged to the branch mainline in revision 341.
  • Revision ID: teddy@recompile.se-20160317204055-bhsh5xsidq7w5cxu
Client: Fix plymouth agent; broken since 1.7.2.

Fix an very old memory bug in the plymouth agent (which has been
present since its apperance in version 1.2), but which was only
recently detected at run time due to the new -fsanitize=address
compile- time flag, which has been used since version 1.7.2.  This
detection of a memory access violation causes the program to abort,
making the Plymouth graphical boot system unable to accept interactive
input of passwords when using the Mandos client.

* plugins.d/plymouth.c (exec_and_wait): Fix memory allocation bug when
  allocating new_argv.  Also tolerate a zero-length argv.

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
28
#include <stdlib.h>             /* malloc(), exit(), EXIT_SUCCESS,
29
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
40
                                   WEXITSTATUS(), WTERMSIG(),
42
41
                                   WCOREDUMP() */
43
 
#include <sys/stat.h>           /* struct stat, stat(), S_ISREG() */
 
42
#include <sys/stat.h>           /* struct stat, fstat(), S_ISREG() */
44
43
#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() */
 
44
#include <dirent.h>             /* struct dirent, scandirat() */
 
45
#include <unistd.h>             /* fcntl(), F_GETFD, F_SETFD,
 
46
                                   FD_CLOEXEC, write(), STDOUT_FILENO,
 
47
                                   struct stat, fstat(), close(),
 
48
                                   setgid(), setuid(), S_ISREG(),
 
49
                                   faccessat() pipe2(), fork(),
 
50
                                   _exit(), dup2(), fexecve(), read()
 
51
                                */
54
52
#include <fcntl.h>              /* fcntl(), F_GETFD, F_SETFD,
55
 
                                   FD_CLOEXEC */
56
 
#include <string.h>             /* strsep, strlen(), asprintf(),
57
 
                                   strsignal() */
 
53
                                   FD_CLOEXEC, openat(), scandirat(),
 
54
                                   pipe2() */
 
55
#include <string.h>             /* strsep, strlen(), strsignal(),
 
56
                                   strcmp(), strncmp() */
58
57
#include <errno.h>              /* errno */
59
58
#include <argp.h>               /* struct argp_option, struct
60
59
                                   argp_state, struct argp,
70
69
#include <inttypes.h>           /* intmax_t, PRIdMAX, strtoimax() */
71
70
#include <sysexits.h>           /* EX_OSERR, EX_USAGE, EX_IOERR,
72
71
                                   EX_CONFIG, EX_UNAVAILABLE, EX_OK */
 
72
#include <errno.h>              /* errno */
 
73
#include <error.h>              /* error() */
 
74
#include <fnmatch.h>            /* fnmatch() */
73
75
 
74
76
#define BUFFER_SIZE 256
75
77
 
76
78
#define PDIR "/lib/mandos/plugins.d"
 
79
#define PHDIR "/lib/mandos/plugin-helpers"
77
80
#define AFILE "/conf/conf.d/mandos/plugin-runner.conf"
78
81
 
79
82
const char *argp_program_version = "plugin-runner " VERSION;
80
 
const char *argp_program_bug_address = "<mandos@fukt.bsnet.se>";
 
83
const char *argp_program_bug_address = "<mandos@recompile.se>";
81
84
 
82
85
typedef struct plugin{
83
86
  char *name;                   /* can be NULL or any plugin name */
103
106
 
104
107
/* Gets an existing plugin based on name,
105
108
   or if none is found, creates a new one */
 
109
__attribute__((warn_unused_result))
106
110
static plugin *getplugin(char *name){
107
111
  /* Check for existing plugin with that name */
108
112
  for(plugin *p = plugin_list; p != NULL; p = p->next){
169
173
}
170
174
 
171
175
/* Helper function for add_argument and add_environment */
 
176
__attribute__((nonnull, warn_unused_result))
172
177
static bool add_to_char_array(const char *new, char ***array,
173
178
                              int *len){
174
179
  /* Resize the pointed-to array to hold one more pointer */
 
180
  char **new_array = NULL;
175
181
  do {
176
 
    *array = realloc(*array, sizeof(char *)
177
 
                     * (size_t) ((*len) + 2));
178
 
  } while(*array == NULL and errno == EINTR);
 
182
    new_array = realloc(*array, sizeof(char *)
 
183
                        * (size_t) ((*len) + 2));
 
184
  } while(new_array == NULL and errno == EINTR);
179
185
  /* Malloc check */
180
 
  if(*array == NULL){
 
186
  if(new_array == NULL){
181
187
    return false;
182
188
  }
 
189
  *array = new_array;
183
190
  /* Make a copy of the new string */
184
191
  char *copy;
185
192
  do {
197
204
}
198
205
 
199
206
/* Add to a plugin's argument vector */
 
207
__attribute__((nonnull(2), warn_unused_result))
200
208
static bool add_argument(plugin *p, const char *arg){
201
209
  if(p == NULL){
202
210
    return false;
205
213
}
206
214
 
207
215
/* Add to a plugin's environment */
 
216
__attribute__((nonnull(2), warn_unused_result))
208
217
static bool add_environment(plugin *p, const char *def, bool replace){
209
218
  if(p == NULL){
210
219
    return false;
212
221
  /* namelen = length of name of environment variable */
213
222
  size_t namelen = (size_t)(strchrnul(def, '=') - def);
214
223
  /* Search for this environment variable */
215
 
  for(char **e = p->environ; *e != NULL; e++){
216
 
    if(strncmp(*e, def, namelen + 1) == 0){
 
224
  for(char **envdef = p->environ; *envdef != NULL; envdef++){
 
225
    if(strncmp(*envdef, def, namelen + 1) == 0){
217
226
      /* It already exists */
218
227
      if(replace){
219
 
        char *new;
 
228
        char *new_envdef;
220
229
        do {
221
 
          new = realloc(*e, strlen(def) + 1);
222
 
        } while(new == NULL and errno == EINTR);
223
 
        if(new == NULL){
 
230
          new_envdef = realloc(*envdef, strlen(def) + 1);
 
231
        } while(new_envdef == NULL and errno == EINTR);
 
232
        if(new_envdef == NULL){
224
233
          return false;
225
234
        }
226
 
        *e = new;
227
 
        strcpy(*e, def);
 
235
        *envdef = new_envdef;
 
236
        strcpy(*envdef, def);
228
237
      }
229
238
      return true;
230
239
    }
232
241
  return add_to_char_array(def, &(p->environ), &(p->envc));
233
242
}
234
243
 
 
244
#ifndef O_CLOEXEC
235
245
/*
236
246
 * Based on the example in the GNU LibC manual chapter 13.13 "File
237
247
 * Descriptor Flags".
238
248
 | [[info:libc:Descriptor%20Flags][File Descriptor Flags]] |
239
249
 */
 
250
__attribute__((warn_unused_result))
240
251
static int set_cloexec_flag(int fd){
241
252
  int ret = (int)TEMP_FAILURE_RETRY(fcntl(fd, F_GETFD, 0));
242
253
  /* If reading the flags failed, return error indication now. */
247
258
  return (int)TEMP_FAILURE_RETRY(fcntl(fd, F_SETFD,
248
259
                                       ret | FD_CLOEXEC));
249
260
}
 
261
#endif  /* not O_CLOEXEC */
250
262
 
251
263
 
252
264
/* Mark processes as completed when they exit, and save their exit
266
278
        /* No child processes */
267
279
        break;
268
280
      }
269
 
      perror("waitpid");
 
281
      error(0, errno, "waitpid");
270
282
    }
271
283
    
272
284
    /* A child exited, find it in process_list */
284
296
}
285
297
 
286
298
/* Prints out a password to stdout */
 
299
__attribute__((nonnull, warn_unused_result))
287
300
static bool print_out_password(const char *buffer, size_t length){
288
301
  ssize_t ret;
289
302
  for(size_t written = 0; written < length; written += (size_t)ret){
297
310
}
298
311
 
299
312
/* Removes and free a plugin from the plugin list */
 
313
__attribute__((nonnull))
300
314
static void free_plugin(plugin *plugin_node){
301
315
  
302
316
  for(char **arg = plugin_node->argv; *arg != NULL; arg++){
334
348
 
335
349
int main(int argc, char *argv[]){
336
350
  char *plugindir = NULL;
 
351
  char *pluginhelperdir = NULL;
337
352
  char *argfile = NULL;
338
353
  FILE *conffp;
339
 
  size_t d_name_len;
340
 
  DIR *dir = NULL;
341
 
  struct dirent *dirst;
 
354
  struct dirent **direntries = NULL;
342
355
  struct stat st;
343
356
  fd_set rfds_all;
344
357
  int ret, maxfd = 0;
352
365
                                      .sa_flags = SA_NOCLDSTOP };
353
366
  char **custom_argv = NULL;
354
367
  int custom_argc = 0;
 
368
  int dir_fd = -1;
355
369
  
356
370
  /* Establish a signal handler */
357
371
  sigemptyset(&sigchld_action.sa_mask);
358
372
  ret = sigaddset(&sigchld_action.sa_mask, SIGCHLD);
359
373
  if(ret == -1){
360
 
    perror("sigaddset");
 
374
    error(0, errno, "sigaddset");
361
375
    exitstatus = EX_OSERR;
362
376
    goto fallback;
363
377
  }
364
378
  ret = sigaction(SIGCHLD, &sigchld_action, &old_sigchld_action);
365
379
  if(ret == -1){
366
 
    perror("sigaction");
 
380
    error(0, errno, "sigaction");
367
381
    exitstatus = EX_OSERR;
368
382
    goto fallback;
369
383
  }
402
416
      .doc = "Group ID the plugins will run as", .group = 3 },
403
417
    { .name = "debug", .key = 132,
404
418
      .doc = "Debug mode", .group = 4 },
 
419
    { .name = "plugin-helper-dir", .key = 133,
 
420
      .arg = "DIRECTORY",
 
421
      .doc = "Specify a different plugin helper directory",
 
422
      .group = 2 },
405
423
    /*
406
424
     * These reproduce what we would get without ARGP_NO_HELP
407
425
     */
414
432
    { .name = NULL }
415
433
  };
416
434
  
 
435
  __attribute__((nonnull(3)))
417
436
  error_t parse_opt(int key, char *arg, struct argp_state *state){
418
437
    errno = 0;
419
438
    switch(key){
420
439
      char *tmp;
421
 
      intmax_t tmpmax;
 
440
      intmax_t tmp_id;
422
441
    case 'g':                   /* --global-options */
423
442
      {
424
443
        char *plugin_option;
427
446
            break;
428
447
          }
429
448
        }
 
449
        errno = 0;
430
450
      }
431
451
      break;
432
452
    case 'G':                   /* --global-env */
433
 
      add_environment(getplugin(NULL), arg, true);
 
453
      if(add_environment(getplugin(NULL), arg, true)){
 
454
        errno = 0;
 
455
      }
434
456
      break;
435
457
    case 'o':                   /* --options-for */
436
458
      {
453
475
            break;
454
476
          }
455
477
        }
 
478
        errno = 0;
456
479
      }
457
480
      break;
458
481
    case 'E':                   /* --env-for */
470
493
          errno = EINVAL;
471
494
          break;
472
495
        }
473
 
        add_environment(getplugin(arg), envdef, true);
 
496
        if(add_environment(getplugin(arg), envdef, true)){
 
497
          errno = 0;
 
498
        }
474
499
      }
475
500
      break;
476
501
    case 'd':                   /* --disable */
478
503
        plugin *p = getplugin(arg);
479
504
        if(p != NULL){
480
505
          p->disabled = true;
 
506
          errno = 0;
481
507
        }
482
508
      }
483
509
      break;
486
512
        plugin *p = getplugin(arg);
487
513
        if(p != NULL){
488
514
          p->disabled = false;
 
515
          errno = 0;
489
516
        }
490
517
      }
491
518
      break;
492
519
    case 128:                   /* --plugin-dir */
493
520
      free(plugindir);
494
521
      plugindir = strdup(arg);
 
522
      if(plugindir != NULL){
 
523
        errno = 0;
 
524
      }
495
525
      break;
496
526
    case 129:                   /* --config-file */
497
527
      /* This is already done by parse_opt_config_file() */
498
528
      break;
499
529
    case 130:                   /* --userid */
500
 
      tmpmax = strtoimax(arg, &tmp, 10);
 
530
      tmp_id = strtoimax(arg, &tmp, 10);
501
531
      if(errno != 0 or tmp == arg or *tmp != '\0'
502
 
         or tmpmax != (uid_t)tmpmax){
 
532
         or tmp_id != (uid_t)tmp_id){
503
533
        argp_error(state, "Bad user ID number: \"%s\", using %"
504
534
                   PRIdMAX, arg, (intmax_t)uid);
505
535
        break;
506
536
      }
507
 
      uid = (uid_t)tmpmax;
 
537
      uid = (uid_t)tmp_id;
 
538
      errno = 0;
508
539
      break;
509
540
    case 131:                   /* --groupid */
510
 
      tmpmax = strtoimax(arg, &tmp, 10);
 
541
      tmp_id = strtoimax(arg, &tmp, 10);
511
542
      if(errno != 0 or tmp == arg or *tmp != '\0'
512
 
         or tmpmax != (gid_t)tmpmax){
 
543
         or tmp_id != (gid_t)tmp_id){
513
544
        argp_error(state, "Bad group ID number: \"%s\", using %"
514
545
                   PRIdMAX, arg, (intmax_t)gid);
515
546
        break;
516
547
      }
517
 
      gid = (gid_t)tmpmax;
 
548
      gid = (gid_t)tmp_id;
 
549
      errno = 0;
518
550
      break;
519
551
    case 132:                   /* --debug */
520
552
      debug = true;
521
553
      break;
 
554
    case 133:                   /* --plugin-helper-dir */
 
555
      free(pluginhelperdir);
 
556
      pluginhelperdir = strdup(arg);
 
557
      if(pluginhelperdir != NULL){
 
558
        errno = 0;
 
559
      }
 
560
      break;
522
561
      /*
523
562
       * These reproduce what we would get without ARGP_NO_HELP
524
563
       */
568
607
    case 129:                   /* --config-file */
569
608
      free(argfile);
570
609
      argfile = strdup(arg);
 
610
      if(argfile != NULL){
 
611
        errno = 0;
 
612
      }
571
613
      break;
572
614
    case 130:                   /* --userid */
573
615
    case 131:                   /* --groupid */
574
616
    case 132:                   /* --debug */
 
617
    case 133:                   /* --plugin-helper-dir */
575
618
    case '?':                   /* --help */
576
619
    case -3:                    /* --usage */
577
620
    case 'V':                   /* --version */
599
642
  case ENOMEM:
600
643
  default:
601
644
    errno = ret;
602
 
    perror("argp_parse");
 
645
    error(0, errno, "argp_parse");
603
646
    exitstatus = EX_OSERR;
604
647
    goto fallback;
605
648
  case EINVAL:
626
669
    custom_argc = 1;
627
670
    custom_argv = malloc(sizeof(char*) * 2);
628
671
    if(custom_argv == NULL){
629
 
      perror("malloc");
 
672
      error(0, errno, "malloc");
630
673
      exitstatus = EX_OSERR;
631
674
      goto fallback;
632
675
    }
649
692
        }
650
693
        new_arg = strdup(p);
651
694
        if(new_arg == NULL){
652
 
          perror("strdup");
 
695
          error(0, errno, "strdup");
653
696
          exitstatus = EX_OSERR;
654
697
          free(org_line);
655
698
          goto fallback;
656
699
        }
657
700
        
658
701
        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;
 
702
        {
 
703
          char **new_argv = realloc(custom_argv, sizeof(char *)
 
704
                                    * ((size_t)custom_argc + 1));
 
705
          if(new_argv == NULL){
 
706
            error(0, errno, "realloc");
 
707
            exitstatus = EX_OSERR;
 
708
            free(new_arg);
 
709
            free(org_line);
 
710
            goto fallback;
 
711
          } else {
 
712
            custom_argv = new_argv;
 
713
          }
666
714
        }
667
715
        custom_argv[custom_argc-1] = new_arg;
668
716
        custom_argv[custom_argc] = NULL;
672
720
      ret = fclose(conffp);
673
721
    } while(ret == EOF and errno == EINTR);
674
722
    if(ret == EOF){
675
 
      perror("fclose");
 
723
      error(0, errno, "fclose");
676
724
      exitstatus = EX_IOERR;
677
725
      goto fallback;
678
726
    }
681
729
    /* Check for harmful errors and go to fallback. Other errors might
682
730
       not affect opening plugins */
683
731
    if(errno == EMFILE or errno == ENFILE or errno == ENOMEM){
684
 
      perror("fopen");
 
732
      error(0, errno, "fopen");
685
733
      exitstatus = EX_OSERR;
686
734
      goto fallback;
687
735
    }
698
746
    case ENOMEM:
699
747
    default:
700
748
      errno = ret;
701
 
      perror("argp_parse");
 
749
      error(0, errno, "argp_parse");
702
750
      exitstatus = EX_OSERR;
703
751
      goto fallback;
704
752
    case EINVAL:
718
766
  case ENOMEM:
719
767
  default:
720
768
    errno = ret;
721
 
    perror("argp_parse");
 
769
    error(0, errno, "argp_parse");
722
770
    exitstatus = EX_OSERR;
723
771
    goto fallback;
724
772
  case EINVAL:
726
774
    goto fallback;
727
775
  }
728
776
  
 
777
  {
 
778
    char *pluginhelperenv;
 
779
    bool bret = true;
 
780
    ret = asprintf(&pluginhelperenv, "MANDOSPLUGINHELPERDIR=%s",
 
781
                   pluginhelperdir != NULL ? pluginhelperdir : PHDIR);
 
782
    if(ret != -1){
 
783
      bret = add_environment(getplugin(NULL), pluginhelperenv, true);
 
784
    }
 
785
    if(ret == -1 or not bret){
 
786
      error(0, errno, "Failed to set MANDOSPLUGINHELPERDIR"
 
787
            " environment variable to \"%s\" for all plugins\n",
 
788
            pluginhelperdir != NULL ? pluginhelperdir : PHDIR);
 
789
    }
 
790
    if(ret != -1){
 
791
      free(pluginhelperenv);
 
792
    }
 
793
  }
 
794
  
729
795
  if(debug){
730
796
    for(plugin *p = plugin_list; p != NULL; p=p->next){
731
797
      fprintf(stderr, "Plugin: %s has %d arguments\n",
740
806
    }
741
807
  }
742
808
  
743
 
  /* Strip permissions down to nobody */
744
 
  setgid(gid);
 
809
  if(getuid() == 0){
 
810
    /* Work around Debian bug #633582:
 
811
       <http://bugs.debian.org/633582> */
 
812
    int plugindir_fd = open(/* plugindir or */ PDIR, O_RDONLY);
 
813
    if(plugindir_fd == -1){
 
814
      if(errno != ENOENT){
 
815
        error(0, errno, "open(\"" PDIR "\")");
 
816
      }
 
817
    } else {
 
818
      ret = (int)TEMP_FAILURE_RETRY(fstat(plugindir_fd, &st));
 
819
      if(ret == -1){
 
820
        error(0, errno, "fstat");
 
821
      } else {
 
822
        if(S_ISDIR(st.st_mode) and st.st_uid == 0 and st.st_gid == 0){
 
823
          ret = fchown(plugindir_fd, uid, gid);
 
824
          if(ret == -1){
 
825
            error(0, errno, "fchown");
 
826
          }
 
827
        }
 
828
      }
 
829
      close(plugindir_fd);
 
830
    }
 
831
  }
 
832
  
 
833
  /* Lower permissions */
 
834
  ret = setgid(gid);
745
835
  if(ret == -1){
746
 
    perror("setgid");
 
836
    error(0, errno, "setgid");
747
837
  }
748
838
  ret = setuid(uid);
749
839
  if(ret == -1){
750
 
    perror("setuid");
 
840
    error(0, errno, "setuid");
751
841
  }
752
842
  
753
843
  /* Open plugin directory with close_on_exec flag */
754
844
  {
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
 
    }
 
845
    dir_fd = open(plugindir != NULL ? plugindir : PDIR, O_RDONLY |
 
846
#ifdef O_CLOEXEC
 
847
                  O_CLOEXEC
 
848
#else  /* not O_CLOEXEC */
 
849
                  0
 
850
#endif  /* not O_CLOEXEC */
 
851
                  );
773
852
    if(dir_fd == -1){
774
 
      perror("Could not open plugin dir");
 
853
      error(0, errno, "Could not open plugin dir");
775
854
      exitstatus = EX_UNAVAILABLE;
776
855
      goto fallback;
777
856
    }
780
859
  /* Set the FD_CLOEXEC flag on the directory */
781
860
    ret = set_cloexec_flag(dir_fd);
782
861
    if(ret < 0){
783
 
      perror("set_cloexec_flag");
784
 
      TEMP_FAILURE_RETRY(close(dir_fd));
 
862
      error(0, errno, "set_cloexec_flag");
785
863
      exitstatus = EX_OSERR;
786
864
      goto fallback;
787
865
    }
788
866
#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;
 
867
  }
 
868
  
 
869
  int good_name(const struct dirent * const dirent){
 
870
    const char * const patterns[] = { ".*", "#*#", "*~", "*.dpkg-new",
 
871
                                      "*.dpkg-old", "*.dpkg-bak",
 
872
                                      "*.dpkg-divert", NULL };
 
873
#ifdef __GNUC__
 
874
#pragma GCC diagnostic push
 
875
#pragma GCC diagnostic ignored "-Wcast-qual"
 
876
#endif
 
877
    for(const char **pat = (const char **)patterns;
 
878
        *pat != NULL; pat++){
 
879
#ifdef __GNUC__
 
880
#pragma GCC diagnostic pop
 
881
#endif
 
882
      if(fnmatch(*pat, dirent->d_name, FNM_FILE_NAME | FNM_PERIOD)
 
883
         != FNM_NOMATCH){
 
884
        if(debug){
 
885
            fprintf(stderr, "Ignoring plugin dir entry \"%s\""
 
886
                    " matching pattern %s\n", dirent->d_name, *pat);
 
887
        }
 
888
        return 0;
 
889
      }
796
890
    }
 
891
    return 1;
 
892
  }
 
893
  
 
894
  int numplugins = scandirat(dir_fd, ".", &direntries, good_name,
 
895
                             alphasort);
 
896
  if(numplugins == -1){
 
897
    error(0, errno, "Could not scan plugin dir");
 
898
    direntries = NULL;
 
899
    exitstatus = EX_OSERR;
 
900
    goto fallback;
797
901
  }
798
902
  
799
903
  FD_ZERO(&rfds_all);
800
904
  
801
905
  /* 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");
 
906
  for(int i = 0; i < numplugins; i++){
 
907
    
 
908
    int plugin_fd = openat(dir_fd, direntries[i]->d_name, O_RDONLY);
 
909
    if(plugin_fd == -1){
 
910
      error(0, errno, "Could not open plugin");
 
911
      free(direntries[i]);
874
912
      continue;
875
913
    }
876
 
    
877
 
    ret = (int)TEMP_FAILURE_RETRY(stat(filename, &st));
 
914
    ret = (int)TEMP_FAILURE_RETRY(fstat(plugin_fd, &st));
878
915
    if(ret == -1){
879
 
      perror("stat");
880
 
      free(filename);
 
916
      error(0, errno, "stat");
 
917
      close(plugin_fd);
 
918
      free(direntries[i]);
881
919
      continue;
882
920
    }
883
921
    
884
922
    /* Ignore non-executable files */
885
923
    if(not S_ISREG(st.st_mode)
886
 
       or (TEMP_FAILURE_RETRY(access(filename, X_OK)) != 0)){
 
924
       or (TEMP_FAILURE_RETRY(faccessat(dir_fd, direntries[i]->d_name,
 
925
                                        X_OK, 0)) != 0)){
887
926
      if(debug){
888
 
        fprintf(stderr, "Ignoring plugin dir entry \"%s\""
889
 
                " with bad type or mode\n", filename);
 
927
        fprintf(stderr, "Ignoring plugin dir entry \"%s/%s\""
 
928
                " with bad type or mode\n",
 
929
                plugindir != NULL ? plugindir : PDIR,
 
930
                direntries[i]->d_name);
890
931
      }
891
 
      free(filename);
 
932
      close(plugin_fd);
 
933
      free(direntries[i]);
892
934
      continue;
893
935
    }
894
936
    
895
 
    plugin *p = getplugin(dirst->d_name);
 
937
    plugin *p = getplugin(direntries[i]->d_name);
896
938
    if(p == NULL){
897
 
      perror("getplugin");
898
 
      free(filename);
 
939
      error(0, errno, "getplugin");
 
940
      close(plugin_fd);
 
941
      free(direntries[i]);
899
942
      continue;
900
943
    }
901
944
    if(p->disabled){
902
945
      if(debug){
903
946
        fprintf(stderr, "Ignoring disabled plugin \"%s\"\n",
904
 
                dirst->d_name);
 
947
                direntries[i]->d_name);
905
948
      }
906
 
      free(filename);
 
949
      close(plugin_fd);
 
950
      free(direntries[i]);
907
951
      continue;
908
952
    }
909
953
    {
912
956
      if(g != NULL){
913
957
        for(char **a = g->argv + 1; *a != NULL; a++){
914
958
          if(not add_argument(p, *a)){
915
 
            perror("add_argument");
 
959
            error(0, errno, "add_argument");
916
960
          }
917
961
        }
918
962
        /* Add global environment variables */
919
963
        for(char **e = g->environ; *e != NULL; e++){
920
964
          if(not add_environment(p, *e, false)){
921
 
            perror("add_environment");
 
965
            error(0, errno, "add_environment");
922
966
          }
923
967
        }
924
968
      }
925
969
    }
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. */
 
970
    /* If this plugin has any environment variables, we need to
 
971
       duplicate the environment from this process, too. */
929
972
    if(p->environ[0] != NULL){
930
973
      for(char **e = environ; *e != NULL; e++){
931
974
        if(not add_environment(p, *e, false)){
932
 
          perror("add_environment");
 
975
          error(0, errno, "add_environment");
933
976
        }
934
977
      }
935
978
    }
936
979
    
937
980
    int pipefd[2];
 
981
#ifndef O_CLOEXEC
938
982
    ret = (int)TEMP_FAILURE_RETRY(pipe(pipefd));
 
983
#else  /* O_CLOEXEC */
 
984
    ret = (int)TEMP_FAILURE_RETRY(pipe2(pipefd, O_CLOEXEC));
 
985
#endif  /* O_CLOEXEC */
939
986
    if(ret == -1){
940
 
      perror("pipe");
941
 
      exitstatus = EX_OSERR;
942
 
      goto fallback;
943
 
    }
 
987
      error(0, errno, "pipe");
 
988
      exitstatus = EX_OSERR;
 
989
      free(direntries[i]);
 
990
      goto fallback;
 
991
    }
 
992
    if(pipefd[0] >= FD_SETSIZE){
 
993
      fprintf(stderr, "pipe()[0] (%d) >= FD_SETSIZE (%d)", pipefd[0],
 
994
              FD_SETSIZE);
 
995
      close(pipefd[0]);
 
996
      close(pipefd[1]);
 
997
      exitstatus = EX_OSERR;
 
998
      free(direntries[i]);
 
999
      goto fallback;
 
1000
    }
 
1001
#ifndef O_CLOEXEC
944
1002
    /* Ask OS to automatic close the pipe on exec */
945
1003
    ret = set_cloexec_flag(pipefd[0]);
946
1004
    if(ret < 0){
947
 
      perror("set_cloexec_flag");
 
1005
      error(0, errno, "set_cloexec_flag");
 
1006
      close(pipefd[0]);
 
1007
      close(pipefd[1]);
948
1008
      exitstatus = EX_OSERR;
 
1009
      free(direntries[i]);
949
1010
      goto fallback;
950
1011
    }
951
1012
    ret = set_cloexec_flag(pipefd[1]);
952
1013
    if(ret < 0){
953
 
      perror("set_cloexec_flag");
 
1014
      error(0, errno, "set_cloexec_flag");
 
1015
      close(pipefd[0]);
 
1016
      close(pipefd[1]);
954
1017
      exitstatus = EX_OSERR;
 
1018
      free(direntries[i]);
955
1019
      goto fallback;
956
1020
    }
 
1021
#endif  /* not O_CLOEXEC */
957
1022
    /* Block SIGCHLD until process is safely in process list */
958
1023
    ret = (int)TEMP_FAILURE_RETRY(sigprocmask(SIG_BLOCK,
959
1024
                                              &sigchld_action.sa_mask,
960
1025
                                              NULL));
961
1026
    if(ret < 0){
962
 
      perror("sigprocmask");
 
1027
      error(0, errno, "sigprocmask");
963
1028
      exitstatus = EX_OSERR;
 
1029
      free(direntries[i]);
964
1030
      goto fallback;
965
1031
    }
966
1032
    /* Starting a new process to be watched */
969
1035
      pid = fork();
970
1036
    } while(pid == -1 and errno == EINTR);
971
1037
    if(pid == -1){
972
 
      perror("fork");
 
1038
      error(0, errno, "fork");
 
1039
      TEMP_FAILURE_RETRY(sigprocmask(SIG_UNBLOCK,
 
1040
                                     &sigchld_action.sa_mask, NULL));
 
1041
      close(pipefd[0]);
 
1042
      close(pipefd[1]);
973
1043
      exitstatus = EX_OSERR;
 
1044
      free(direntries[i]);
974
1045
      goto fallback;
975
1046
    }
976
1047
    if(pid == 0){
977
1048
      /* this is the child process */
978
1049
      ret = sigaction(SIGCHLD, &old_sigchld_action, NULL);
979
1050
      if(ret < 0){
980
 
        perror("sigaction");
 
1051
        error(0, errno, "sigaction");
981
1052
        _exit(EX_OSERR);
982
1053
      }
983
1054
      ret = sigprocmask(SIG_UNBLOCK, &sigchld_action.sa_mask, NULL);
984
1055
      if(ret < 0){
985
 
        perror("sigprocmask");
 
1056
        error(0, errno, "sigprocmask");
986
1057
        _exit(EX_OSERR);
987
1058
      }
988
1059
      
989
1060
      ret = dup2(pipefd[1], STDOUT_FILENO); /* replace our stdout */
990
1061
      if(ret == -1){
991
 
        perror("dup2");
 
1062
        error(0, errno, "dup2");
992
1063
        _exit(EX_OSERR);
993
1064
      }
994
1065
      
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
 
        }
 
1066
      if(fexecve(plugin_fd, p->argv,
 
1067
                (p->environ[0] != NULL) ? p->environ : environ) < 0){
 
1068
        error(0, errno, "fexecve for %s/%s",
 
1069
              plugindir != NULL ? plugindir : PDIR,
 
1070
              direntries[i]->d_name);
 
1071
        _exit(EX_OSERR);
1010
1072
      }
1011
1073
      /* no return */
1012
1074
    }
1013
1075
    /* 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);
 
1076
    close(pipefd[1]);           /* Close unused write end of pipe */
 
1077
    close(plugin_fd);
 
1078
    plugin *new_plugin = getplugin(direntries[i]->d_name);
1018
1079
    if(new_plugin == NULL){
1019
 
      perror("getplugin");
 
1080
      error(0, errno, "getplugin");
1020
1081
      ret = (int)(TEMP_FAILURE_RETRY
1021
1082
                  (sigprocmask(SIG_UNBLOCK, &sigchld_action.sa_mask,
1022
1083
                               NULL)));
1023
1084
      if(ret < 0){
1024
 
        perror("sigprocmask");
 
1085
        error(0, errno, "sigprocmask");
1025
1086
      }
1026
1087
      exitstatus = EX_OSERR;
 
1088
      free(direntries[i]);
1027
1089
      goto fallback;
1028
1090
    }
 
1091
    free(direntries[i]);
1029
1092
    
1030
1093
    new_plugin->pid = pid;
1031
1094
    new_plugin->fd = pipefd[0];
1036
1099
                                              &sigchld_action.sa_mask,
1037
1100
                                              NULL));
1038
1101
    if(ret < 0){
1039
 
      perror("sigprocmask");
 
1102
      error(0, errno, "sigprocmask");
1040
1103
      exitstatus = EX_OSERR;
1041
1104
      goto fallback;
1042
1105
    }
1043
1106
    
1044
 
    FD_SET(new_plugin->fd, &rfds_all); /* Spurious warning from
1045
 
                                          -Wconversion */
 
1107
    FD_SET(new_plugin->fd, &rfds_all);
1046
1108
    
1047
1109
    if(maxfd < new_plugin->fd){
1048
1110
      maxfd = new_plugin->fd;
1049
1111
    }
1050
1112
  }
1051
1113
  
1052
 
  TEMP_FAILURE_RETRY(closedir(dir));
1053
 
  dir = NULL;
 
1114
  free(direntries);
 
1115
  direntries = NULL;
 
1116
  close(dir_fd);
 
1117
  dir_fd = -1;
1054
1118
  free_plugin(getplugin(NULL));
1055
1119
  
1056
1120
  for(plugin *p = plugin_list; p != NULL; p = p->next){
1069
1133
    fd_set rfds = rfds_all;
1070
1134
    int select_ret = select(maxfd+1, &rfds, NULL, NULL, NULL);
1071
1135
    if(select_ret == -1 and errno != EINTR){
1072
 
      perror("select");
 
1136
      error(0, errno, "select");
1073
1137
      exitstatus = EX_OSERR;
1074
1138
      goto fallback;
1075
1139
    }
1102
1166
          }
1103
1167
          
1104
1168
          /* Remove the plugin */
1105
 
          FD_CLR(proc->fd, &rfds_all); /* Spurious warning from
1106
 
                                          -Wconversion */
 
1169
          FD_CLR(proc->fd, &rfds_all);
1107
1170
          
1108
1171
          /* Block signal while modifying process_list */
1109
1172
          ret = (int)TEMP_FAILURE_RETRY(sigprocmask
1111
1174
                                         &sigchld_action.sa_mask,
1112
1175
                                         NULL));
1113
1176
          if(ret < 0){
1114
 
            perror("sigprocmask");
 
1177
            error(0, errno, "sigprocmask");
1115
1178
            exitstatus = EX_OSERR;
1116
1179
            goto fallback;
1117
1180
          }
1125
1188
                      (sigprocmask(SIG_UNBLOCK,
1126
1189
                                   &sigchld_action.sa_mask, NULL)));
1127
1190
          if(ret < 0){
1128
 
            perror("sigprocmask");
 
1191
            error(0, errno, "sigprocmask");
1129
1192
            exitstatus = EX_OSERR;
1130
1193
            goto fallback;
1131
1194
          }
1142
1205
        bool bret = print_out_password(proc->buffer,
1143
1206
                                       proc->buffer_length);
1144
1207
        if(not bret){
1145
 
          perror("print_out_password");
 
1208
          error(0, errno, "print_out_password");
1146
1209
          exitstatus = EX_IOERR;
1147
1210
        }
1148
1211
        goto fallback;
1149
1212
      }
1150
1213
      
1151
1214
      /* 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 */
 
1215
      if(proc->eof or not FD_ISSET(proc->fd, &rfds)){
1155
1216
        /* This process had nothing to say at this time */
1156
1217
        proc = proc->next;
1157
1218
        continue;
1158
1219
      }
1159
1220
      /* Before reading, make the process' data buffer large enough */
1160
1221
      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");
 
1222
        char *new_buffer = realloc(proc->buffer, proc->buffer_size
 
1223
                                   + (size_t) BUFFER_SIZE);
 
1224
        if(new_buffer == NULL){
 
1225
          error(0, errno, "malloc");
1165
1226
          exitstatus = EX_OSERR;
1166
1227
          goto fallback;
1167
1228
        }
 
1229
        proc->buffer = new_buffer;
1168
1230
        proc->buffer_size += BUFFER_SIZE;
1169
1231
      }
1170
1232
      /* Read from the process */
1204
1266
    }
1205
1267
    bret = print_out_password(passwordbuffer, len);
1206
1268
    if(not bret){
1207
 
      perror("print_out_password");
 
1269
      error(0, errno, "print_out_password");
1208
1270
      exitstatus = EX_IOERR;
1209
1271
    }
1210
1272
  }
1212
1274
  /* Restore old signal handler */
1213
1275
  ret = sigaction(SIGCHLD, &old_sigchld_action, NULL);
1214
1276
  if(ret == -1){
1215
 
    perror("sigaction");
 
1277
    error(0, errno, "sigaction");
1216
1278
    exitstatus = EX_OSERR;
1217
1279
  }
1218
1280
  
1223
1285
    free(custom_argv);
1224
1286
  }
1225
1287
  
1226
 
  if(dir != NULL){
1227
 
    closedir(dir);
 
1288
  free(direntries);
 
1289
  
 
1290
  if(dir_fd != -1){
 
1291
    close(dir_fd);
1228
1292
  }
1229
1293
  
1230
1294
  /* Kill the processes */
1234
1298
      ret = kill(p->pid, SIGTERM);
1235
1299
      if(ret == -1 and errno != ESRCH){
1236
1300
        /* Set-uid proccesses might not get closed */
1237
 
        perror("kill");
 
1301
        error(0, errno, "kill");
1238
1302
      }
1239
1303
    }
1240
1304
  }
1244
1308
    ret = wait(NULL);
1245
1309
  } while(ret >= 0);
1246
1310
  if(errno != ECHILD){
1247
 
    perror("wait");
 
1311
    error(0, errno, "wait");
1248
1312
  }
1249
1313
  
1250
1314
  free_plugin_list();
1251
1315
  
1252
1316
  free(plugindir);
 
1317
  free(pluginhelperdir);
1253
1318
  free(argfile);
1254
1319
  
1255
1320
  return exitstatus;