19
19
 * along with this program.  If not, see
 
20
20
 * <http://www.gnu.org/licenses/>.
 
22
 
 * Contact the authors at <mandos@recompile.se>.
 
 
22
 * Contact the authors at <mandos@fukt.bsnet.se>.
 
25
25
#define _GNU_SOURCE             /* TEMP_FAILURE_RETRY(), getline(),
 
26
 
                                   asprintf(), O_CLOEXEC */
 
27
27
#include <stddef.h>             /* size_t, NULL */
 
28
 
#include <stdlib.h>             /* malloc(), exit(), EXIT_SUCCESS,
 
 
28
#include <stdlib.h>             /* malloc(), exit(), EXIT_FAILURE,
 
 
29
                                   EXIT_SUCCESS, realloc() */
 
30
30
#include <stdbool.h>            /* bool, true, false */
 
31
 
#include <stdio.h>              /* fileno(), fprintf(),
 
 
31
#include <stdio.h>              /* perror, fileno(), fprintf(),
 
32
32
                                   stderr, STDOUT_FILENO */
 
33
 
#include <sys/types.h>          /* DIR, fdopendir(), stat(), struct
 
 
33
#include <sys/types.h>          /* DIR, opendir(), stat(), struct
 
34
34
                                   stat, waitpid(), WIFEXITED(),
 
35
35
                                   WEXITSTATUS(), wait(), pid_t,
 
36
36
                                   uid_t, gid_t, getuid(), getgid(),
 
 
413
393
      .doc = "Group ID the plugins will run as", .group = 3 },
 
414
394
    { .name = "debug", .key = 132,
 
415
395
      .doc = "Debug mode", .group = 4 },
 
417
 
     * These reproduce what we would get without ARGP_NO_HELP
 
419
 
    { .name = "help", .key = '?',
 
420
 
      .doc = "Give this help list", .group = -1 },
 
421
 
    { .name = "usage", .key = -3,
 
422
 
      .doc = "Give a short usage message", .group = -1 },
 
423
 
    { .name = "version", .key = 'V',
 
424
 
      .doc = "Print program version", .group = -1 },
 
428
 
  __attribute__((nonnull(3)))
 
429
 
  error_t parse_opt(int key, char *arg, struct argp_state *state){
 
 
399
  error_t parse_opt(int key, char *arg, __attribute__((unused))
 
 
400
                    struct argp_state *state){
 
434
404
    case 'g':                   /* --global-options */
 
436
406
        char *plugin_option;
 
437
407
        while((plugin_option = strsep(&arg, ",")) != NULL){
 
 
408
          if(plugin_option[0] == '\0'){
 
438
411
          if(not add_argument(getplugin(NULL), plugin_option)){
 
 
412
            perror("add_argument");
 
 
413
            return ARGP_ERR_UNKNOWN;
 
445
418
    case 'G':                   /* --global-env */
 
446
 
      if(add_environment(getplugin(NULL), arg, true)){
 
 
422
      if(not add_environment(getplugin(NULL), arg, true)){
 
 
423
        perror("add_environment");
 
450
426
    case 'o':                   /* --options-for */
 
452
 
        char *option_list = strchr(arg, ':');
 
453
 
        if(option_list == NULL){
 
454
 
          argp_error(state, "No colon in \"%s\"", arg);
 
461
 
          argp_error(state, "Empty plugin name");
 
466
 
        while((option = strsep(&option_list, ",")) != NULL){
 
467
 
          if(not add_argument(getplugin(arg), option)){
 
 
428
        char *plugin_name = strsep(&arg, ":");
 
 
429
        if(plugin_name[0] == '\0'){
 
 
433
        while((plugin_option = strsep(&arg, ",")) != NULL){
 
 
434
          if(not add_argument(getplugin(plugin_name), plugin_option)){
 
 
435
            perror("add_argument");
 
 
436
            return ARGP_ERR_UNKNOWN;
 
474
441
    case 'E':                   /* --env-for */
 
476
446
        char *envdef = strchr(arg, ':');
 
477
447
        if(envdef == NULL){
 
478
 
          argp_error(state, "No colon in \"%s\"", arg);
 
485
 
          argp_error(state, "Empty plugin name");
 
489
 
        if(add_environment(getplugin(arg), envdef, true)){
 
 
451
        if(not add_environment(getplugin(arg), envdef+1, true)){
 
 
452
          perror("add_environment");
 
494
456
    case 'd':                   /* --disable */
 
496
458
        plugin *p = getplugin(arg);
 
 
460
          return ARGP_ERR_UNKNOWN;
 
503
465
    case 'e':                   /* --enable */
 
505
467
        plugin *p = getplugin(arg);
 
 
469
          return ARGP_ERR_UNKNOWN;
 
512
474
    case 128:                   /* --plugin-dir */
 
514
476
      plugindir = strdup(arg);
 
515
 
      if(plugindir != NULL){
 
 
477
      if(plugindir == NULL){
 
519
481
    case 129:                   /* --config-file */
 
520
482
      /* This is already done by parse_opt_config_file() */
 
522
484
    case 130:                   /* --userid */
 
523
 
      tmp_id = strtoimax(arg, &tmp, 10);
 
 
486
      tmpmax = strtoimax(arg, &tmp, 10);
 
524
487
      if(errno != 0 or tmp == arg or *tmp != '\0'
 
525
 
         or tmp_id != (uid_t)tmp_id){
 
526
 
        argp_error(state, "Bad user ID number: \"%s\", using %"
 
527
 
                   PRIdMAX, arg, (intmax_t)uid);
 
 
488
         or tmpmax != (uid_t)tmpmax){
 
 
489
        fprintf(stderr, "Bad user ID number: \"%s\", using %"
 
 
490
                PRIdMAX "\n", arg, (intmax_t)uid);
 
533
495
    case 131:                   /* --groupid */
 
534
 
      tmp_id = strtoimax(arg, &tmp, 10);
 
 
497
      tmpmax = strtoimax(arg, &tmp, 10);
 
535
498
      if(errno != 0 or tmp == arg or *tmp != '\0'
 
536
 
         or tmp_id != (gid_t)tmp_id){
 
537
 
        argp_error(state, "Bad group ID number: \"%s\", using %"
 
538
 
                   PRIdMAX, arg, (intmax_t)gid);
 
 
499
         or tmpmax != (gid_t)tmpmax){
 
 
500
        fprintf(stderr, "Bad group ID number: \"%s\", using %"
 
 
501
                PRIdMAX "\n", arg, (intmax_t)gid);
 
544
506
    case 132:                   /* --debug */
 
548
 
       * These reproduce what we would get without ARGP_NO_HELP
 
550
 
    case '?':                   /* --help */
 
551
 
      state->flags &= ~(unsigned int)ARGP_NO_EXIT; /* force exit */
 
552
 
      argp_state_help(state, state->out_stream, ARGP_HELP_STD_HELP);
 
553
 
    case -3:                    /* --usage */
 
554
 
      state->flags &= ~(unsigned int)ARGP_NO_EXIT; /* force exit */
 
555
 
      argp_state_help(state, state->out_stream,
 
556
 
                      ARGP_HELP_USAGE | ARGP_HELP_EXIT_OK);
 
557
 
    case 'V':                   /* --version */
 
558
 
      fprintf(state->out_stream, "%s\n", argp_program_version);
 
562
510
 * When adding more options before this line, remember to also add a
 
563
511
 * "case" to the "parse_opt_config_file" function below.
 
 
715
647
    /* Check for harmful errors and go to fallback. Other errors might
 
716
648
       not affect opening plugins */
 
717
649
    if(errno == EMFILE or errno == ENFILE or errno == ENOMEM){
 
718
 
      error(0, errno, "fopen");
 
719
 
      exitstatus = EX_OSERR;
 
 
651
      exitstatus = EXIT_FAILURE;
 
723
 
  /* If there were any arguments from the configuration file, pass
 
724
 
     them to parser as command line arguments */
 
 
655
  /* If there was any arguments from configuration file,
 
 
656
     pass them to parser as command arguments */
 
725
657
  if(custom_argv != NULL){
 
726
 
    ret = argp_parse(&argp, custom_argc, custom_argv,
 
727
 
                     ARGP_IN_ORDER | ARGP_NO_EXIT | ARGP_NO_HELP,
 
735
 
      error(0, errno, "argp_parse");
 
736
 
      exitstatus = EX_OSERR;
 
739
 
      exitstatus = EX_CONFIG;
 
 
658
    ret = argp_parse(&argp, custom_argc, custom_argv, ARGP_IN_ORDER,
 
 
660
    if(ret == ARGP_ERR_UNKNOWN){
 
 
661
      fprintf(stderr, "Unknown error while parsing arguments\n");
 
 
662
      exitstatus = EXIT_FAILURE;
 
744
667
  /* Parse actual command line arguments, to let them override the
 
746
 
  ret = argp_parse(&argp, argc, argv,
 
747
 
                   ARGP_IN_ORDER | ARGP_NO_EXIT | ARGP_NO_HELP,
 
755
 
    error(0, errno, "argp_parse");
 
756
 
    exitstatus = EX_OSERR;
 
759
 
    exitstatus = EX_USAGE;
 
 
669
  ret = argp_parse(&argp, argc, argv, ARGP_IN_ORDER, 0, NULL);
 
 
670
  if(ret == ARGP_ERR_UNKNOWN){
 
 
671
    fprintf(stderr, "Unknown error while parsing arguments\n");
 
 
672
    exitstatus = EXIT_FAILURE;
 
 
778
 
    /* Work around Debian bug #633582:
 
779
 
       <http://bugs.debian.org/633582> */
 
780
 
    int plugindir_fd = open(/* plugindir or */ PDIR, O_RDONLY);
 
781
 
    if(plugindir_fd == -1){
 
782
 
      error(0, errno, "open");
 
784
 
      ret = (int)TEMP_FAILURE_RETRY(fstat(plugindir_fd, &st));
 
786
 
        error(0, errno, "fstat");
 
788
 
        if(S_ISDIR(st.st_mode) and st.st_uid == 0 and st.st_gid == 0){
 
789
 
          ret = fchown(plugindir_fd, uid, gid);
 
791
 
            error(0, errno, "fchown");
 
795
 
      TEMP_FAILURE_RETRY(close(plugindir_fd));
 
799
 
  /* Lower permissions */
 
 
690
  /* Strip permissions down to nobody */
 
802
 
    error(0, errno, "setgid");
 
804
695
  ret = setuid(uid);
 
806
 
    error(0, errno, "setuid");
 
809
 
  /* Open plugin directory with close_on_exec flag */
 
 
700
  if(plugindir == NULL){
 
 
703
    dir = opendir(plugindir);
 
 
707
    perror("Could not open plugin dir");
 
 
708
    exitstatus = EXIT_FAILURE;
 
 
712
  /* Set the FD_CLOEXEC flag on the directory, if possible */
 
812
 
    if(plugindir == NULL){
 
813
 
      dir_fd = open(PDIR, O_RDONLY |
 
816
 
#else  /* not O_CLOEXEC */
 
818
 
#endif  /* not O_CLOEXEC */
 
821
 
      dir_fd = open(plugindir, O_RDONLY |
 
824
 
#else  /* not O_CLOEXEC */
 
826
 
#endif  /* not O_CLOEXEC */
 
830
 
      error(0, errno, "Could not open plugin dir");
 
831
 
      exitstatus = EX_UNAVAILABLE;
 
836
 
  /* Set the FD_CLOEXEC flag on the directory */
 
837
 
    ret = set_cloexec_flag(dir_fd);
 
839
 
      error(0, errno, "set_cloexec_flag");
 
840
 
      TEMP_FAILURE_RETRY(close(dir_fd));
 
841
 
      exitstatus = EX_OSERR;
 
844
 
#endif  /* O_CLOEXEC */
 
846
 
    dir = fdopendir(dir_fd);
 
848
 
      error(0, errno, "Could not open plugin dir");
 
849
 
      TEMP_FAILURE_RETRY(close(dir_fd));
 
850
 
      exitstatus = EX_OSERR;
 
 
714
    int dir_fd = dirfd(dir);
 
 
716
      ret = set_cloexec_flag(dir_fd);
 
 
718
        perror("set_cloexec_flag");
 
 
719
        exitstatus = EXIT_FAILURE;
 
 
1001
854
    if(p->environ[0] != NULL){
 
1002
855
      for(char **e = environ; *e != NULL; e++){
 
1003
856
        if(not add_environment(p, *e, false)){
 
1004
 
          error(0, errno, "add_environment");
 
 
857
          perror("add_environment");
 
1010
 
    ret = (int)TEMP_FAILURE_RETRY(pipe(pipefd));
 
 
863
    ret = TEMP_FAILURE_RETRY(pipe(pipefd));
 
1012
 
      error(0, errno, "pipe");
 
1013
 
      exitstatus = EX_OSERR;
 
 
866
      exitstatus = EXIT_FAILURE;
 
1016
869
    /* Ask OS to automatic close the pipe on exec */
 
1017
870
    ret = set_cloexec_flag(pipefd[0]);
 
1019
 
      error(0, errno, "set_cloexec_flag");
 
1020
 
      exitstatus = EX_OSERR;
 
 
872
      perror("set_cloexec_flag");
 
 
873
      exitstatus = EXIT_FAILURE;
 
1023
876
    ret = set_cloexec_flag(pipefd[1]);
 
1025
 
      error(0, errno, "set_cloexec_flag");
 
1026
 
      exitstatus = EX_OSERR;
 
 
878
      perror("set_cloexec_flag");
 
 
879
      exitstatus = EXIT_FAILURE;
 
1029
882
    /* Block SIGCHLD until process is safely in process list */
 
1030
 
    ret = (int)TEMP_FAILURE_RETRY(sigprocmask(SIG_BLOCK,
 
1031
 
                                              &sigchld_action.sa_mask,
 
 
883
    ret = TEMP_FAILURE_RETRY(sigprocmask(SIG_BLOCK,
 
 
884
                                         &sigchld_action.sa_mask,
 
1034
 
      error(0, errno, "sigprocmask");
 
1035
 
      exitstatus = EX_OSERR;
 
 
887
      perror("sigprocmask");
 
 
888
      exitstatus = EXIT_FAILURE;
 
1038
891
    /* Starting a new process to be watched */
 
 
1105
958
    /* Unblock SIGCHLD so signal handler can be run if this process
 
1106
959
       has already completed */
 
1107
 
    ret = (int)TEMP_FAILURE_RETRY(sigprocmask(SIG_UNBLOCK,
 
1108
 
                                              &sigchld_action.sa_mask,
 
 
960
    ret = TEMP_FAILURE_RETRY(sigprocmask(SIG_UNBLOCK,
 
 
961
                                         &sigchld_action.sa_mask,
 
1111
 
      error(0, errno, "sigprocmask");
 
1112
 
      exitstatus = EX_OSERR;
 
 
964
      perror("sigprocmask");
 
 
965
      exitstatus = EXIT_FAILURE;
 
1116
 
#if defined (__GNUC__) and defined (__GLIBC__)
 
1117
 
#if not __GLIBC_PREREQ(2, 16)
 
1118
 
#pragma GCC diagnostic push
 
1119
 
#pragma GCC diagnostic ignored "-Wsign-conversion"
 
1122
 
    FD_SET(new_plugin->fd, &rfds_all); /* Spurious warning from
 
1123
 
                                          -Wconversion in GNU libc
 
1125
 
#if defined (__GNUC__) and defined (__GLIBC__)
 
1126
 
#if not __GLIBC_PREREQ(2, 16)
 
1127
 
#pragma GCC diagnostic pop
 
 
969
    FD_SET(new_plugin->fd, &rfds_all);
 
1131
971
    if(maxfd < new_plugin->fd){
 
1132
972
      maxfd = new_plugin->fd;
 
 
1238
1064
        bool bret = print_out_password(proc->buffer,
 
1239
1065
                                       proc->buffer_length);
 
1241
 
          error(0, errno, "print_out_password");
 
1242
 
          exitstatus = EX_IOERR;
 
 
1067
          perror("print_out_password");
 
 
1068
          exitstatus = EXIT_FAILURE;
 
1247
1073
      /* This process has not completed.  Does it have any output? */
 
1248
 
#if defined (__GNUC__) and defined (__GLIBC__)
 
1249
 
#if not __GLIBC_PREREQ(2, 16)
 
1250
 
#pragma GCC diagnostic push
 
1251
 
#pragma GCC diagnostic ignored "-Wsign-conversion"
 
1254
 
      if(proc->eof or not FD_ISSET(proc->fd, &rfds)){ /* Spurious
 
1260
 
#if defined (__GNUC__) and defined (__GLIBC__)
 
1261
 
#if not __GLIBC_PREREQ(2, 16)
 
1262
 
#pragma GCC diagnostic pop
 
 
1074
      if(proc->eof or not FD_ISSET(proc->fd, &rfds)){
 
1265
1075
        /* This process had nothing to say at this time */
 
1266
1076
        proc = proc->next;
 
1269
1079
      /* Before reading, make the process' data buffer large enough */
 
1270
1080
      if(proc->buffer_length + BUFFER_SIZE > proc->buffer_size){
 
1271
 
        char *new_buffer = realloc(proc->buffer, proc->buffer_size
 
1272
 
                                   + (size_t) BUFFER_SIZE);
 
1273
 
        if(new_buffer == NULL){
 
1274
 
          error(0, errno, "malloc");
 
1275
 
          exitstatus = EX_OSERR;
 
 
1081
        proc->buffer = realloc(proc->buffer, proc->buffer_size
 
 
1082
                               + (size_t) BUFFER_SIZE);
 
 
1083
        if(proc->buffer == NULL){
 
 
1085
          exitstatus = EXIT_FAILURE;
 
1278
 
        proc->buffer = new_buffer;
 
1279
1088
        proc->buffer_size += BUFFER_SIZE;
 
1281
1090
      /* Read from the process */