/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: 2021-02-04 17:59:45 UTC
  • Revision ID: teddy@recompile.se-20210204175945-8druo6d88ipc1z58
Fix issue with french translation

Initial white space was missing in both msgid and msgstr of the french
translation, leading to checking tools reporing an incomplete
translation.  The string is a raw key id, and therefore did not need
translation, so this was never a user-visible issue.

* debian/po/fr.po: Add missing whitespace to the id and translation
  for msgid " ${key_id}".

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-2014 Teddy Hogeborn
6
 
 * Copyright © 2008-2014 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-2021 Teddy Hogeborn
 
6
 * Copyright © 2008-2021 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
23
 * Contact the authors at <mandos@recompile.se>.
23
24
 */
24
25
 
25
 
#define _GNU_SOURCE             /* TEMP_FAILURE_RETRY(), getline(),
26
 
                                   O_CLOEXEC, pipe2() */
 
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>              /* 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() */
37
 
#include <sys/select.h>         /* fd_set, select(), FD_ZERO(),
38
 
                                   FD_SET(), FD_ISSET(), FD_CLR */
39
 
#include <sys/wait.h>           /* wait(), waitpid(), WIFEXITED(),
40
 
                                   WEXITSTATUS(), WTERMSIG(),
41
 
                                   WCOREDUMP() */
42
 
#include <sys/stat.h>           /* struct stat, fstat(), S_ISREG() */
43
 
#include <iso646.h>             /* and, or, not */
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
 
                                */
 
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() */
52
63
#include <fcntl.h>              /* fcntl(), F_GETFD, F_SETFD,
53
 
                                   FD_CLOEXEC, openat(), scandirat(),
54
 
                                   pipe2() */
55
 
#include <string.h>             /* strsep, strlen(), strsignal(),
56
 
                                   strcmp(), strncmp() */
57
 
#include <errno.h>              /* errno */
58
 
#include <argp.h>               /* struct argp_option, struct
59
 
                                   argp_state, struct argp,
60
 
                                   argp_parse(), ARGP_ERR_UNKNOWN,
61
 
                                   ARGP_KEY_END, ARGP_KEY_ARG,
62
 
                                   error_t */
63
 
#include <signal.h>             /* struct sigaction, sigemptyset(),
64
 
                                   sigaddset(), sigaction(),
65
 
                                   sigprocmask(), SIG_BLOCK, SIGCHLD,
66
 
                                   SIG_UNBLOCK, kill(), sig_atomic_t
67
 
                                */
68
 
#include <errno.h>              /* errno, EBADF */
69
 
#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 */
70
84
#include <sysexits.h>           /* EX_OSERR, EX_USAGE, EX_IOERR,
71
85
                                   EX_CONFIG, EX_UNAVAILABLE, EX_OK */
72
 
#include <errno.h>              /* errno */
73
 
#include <error.h>              /* error() */
74
 
#include <fnmatch.h>            /* fnmatch() */
 
86
#include <inttypes.h>           /* intmax_t, strtoimax(), PRIdMAX */
 
87
#include <fnmatch.h>            /* fnmatch(), FNM_FILE_NAME,
 
88
                                   FNM_PERIOD, FNM_NOMATCH */
75
89
 
76
90
#define BUFFER_SIZE 256
77
91
 
78
92
#define PDIR "/lib/mandos/plugins.d"
 
93
#define PHDIR "/lib/mandos/plugin-helpers"
79
94
#define AFILE "/conf/conf.d/mandos/plugin-runner.conf"
80
95
 
81
96
const char *argp_program_version = "plugin-runner " VERSION;
178
193
  /* Resize the pointed-to array to hold one more pointer */
179
194
  char **new_array = NULL;
180
195
  do {
181
 
    new_array = realloc(*array, sizeof(char *)
182
 
                        * (size_t) ((*len) + 2));
 
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
183
209
  } while(new_array == NULL and errno == EINTR);
184
210
  /* Malloc check */
185
211
  if(new_array == NULL){
312
338
__attribute__((nonnull))
313
339
static void free_plugin(plugin *plugin_node){
314
340
  
315
 
  for(char **arg = plugin_node->argv; *arg != NULL; arg++){
 
341
  for(char **arg = (plugin_node->argv)+1; *arg != NULL; arg++){
316
342
    free(*arg);
317
343
  }
 
344
  free(plugin_node->name);
318
345
  free(plugin_node->argv);
319
346
  for(char **env = plugin_node->environ; *env != NULL; env++){
320
347
    free(*env);
347
374
 
348
375
int main(int argc, char *argv[]){
349
376
  char *plugindir = NULL;
 
377
  char *pluginhelperdir = NULL;
350
378
  char *argfile = NULL;
351
379
  FILE *conffp;
352
 
  struct dirent **direntries;
 
380
  struct dirent **direntries = NULL;
353
381
  struct stat st;
354
382
  fd_set rfds_all;
355
383
  int ret, maxfd = 0;
414
442
      .doc = "Group ID the plugins will run as", .group = 3 },
415
443
    { .name = "debug", .key = 132,
416
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 },
417
449
    /*
418
450
     * These reproduce what we would get without ARGP_NO_HELP
419
451
     */
545
577
    case 132:                   /* --debug */
546
578
      debug = true;
547
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;
548
587
      /*
549
588
       * These reproduce what we would get without ARGP_NO_HELP
550
589
       */
551
590
    case '?':                   /* --help */
552
591
      state->flags &= ~(unsigned int)ARGP_NO_EXIT; /* force exit */
553
592
      argp_state_help(state, state->out_stream, ARGP_HELP_STD_HELP);
 
593
      __builtin_unreachable();
554
594
    case -3:                    /* --usage */
555
595
      state->flags &= ~(unsigned int)ARGP_NO_EXIT; /* force exit */
556
596
      argp_state_help(state, state->out_stream,
557
597
                      ARGP_HELP_USAGE | ARGP_HELP_EXIT_OK);
 
598
      __builtin_unreachable();
558
599
    case 'V':                   /* --version */
559
600
      fprintf(state->out_stream, "%s\n", argp_program_version);
560
601
      exit(EXIT_SUCCESS);
570
611
      if(arg[0] == '\0'){
571
612
        break;
572
613
      }
 
614
#if __GNUC__ >= 7
 
615
      __attribute__((fallthrough));
 
616
#else
 
617
          /* FALLTHROUGH */
 
618
#endif
573
619
    default:
574
620
      return ARGP_ERR_UNKNOWN;
575
621
    }
601
647
    case 130:                   /* --userid */
602
648
    case 131:                   /* --groupid */
603
649
    case 132:                   /* --debug */
 
650
    case 133:                   /* --plugin-helper-dir */
604
651
    case '?':                   /* --help */
605
652
    case -3:                    /* --usage */
606
653
    case 'V':                   /* --version */
686
733
        
687
734
        custom_argc += 1;
688
735
        {
689
 
          char **new_argv = realloc(custom_argv, sizeof(char *)
690
 
                                    * ((unsigned int)
691
 
                                       custom_argc + 1));
 
736
#if defined(__GLIBC_PREREQ) and __GLIBC_PREREQ(2, 26)
 
737
          char **new_argv = reallocarray(custom_argv, (size_t)custom_argc + 1,
 
738
                                         sizeof(char *));
 
739
#else
 
740
          char **new_argv = NULL;
 
741
          if(((size_t)custom_argc + 1) > (SIZE_MAX / sizeof(char *))){
 
742
            /* overflow */
 
743
            errno = ENOMEM;
 
744
          } else {
 
745
            new_argv = realloc(custom_argv, ((size_t)custom_argc + 1)
 
746
                               * sizeof(char *));
 
747
          }
 
748
#endif
692
749
          if(new_argv == NULL){
693
 
            error(0, errno, "realloc");
 
750
            error(0, errno, "reallocarray");
694
751
            exitstatus = EX_OSERR;
695
752
            free(new_arg);
696
753
            free(org_line);
761
818
    goto fallback;
762
819
  }
763
820
  
 
821
  {
 
822
    char *pluginhelperenv;
 
823
    bool bret = true;
 
824
    ret = asprintf(&pluginhelperenv, "MANDOSPLUGINHELPERDIR=%s",
 
825
                   pluginhelperdir != NULL ? pluginhelperdir : PHDIR);
 
826
    if(ret != -1){
 
827
      bret = add_environment(getplugin(NULL), pluginhelperenv, true);
 
828
    }
 
829
    if(ret == -1 or not bret){
 
830
      error(0, errno, "Failed to set MANDOSPLUGINHELPERDIR"
 
831
            " environment variable to \"%s\" for all plugins\n",
 
832
            pluginhelperdir != NULL ? pluginhelperdir : PHDIR);
 
833
    }
 
834
    if(ret != -1){
 
835
      free(pluginhelperenv);
 
836
    }
 
837
  }
 
838
  
764
839
  if(debug){
765
 
    for(plugin *p = plugin_list; p != NULL; p=p->next){
 
840
    for(plugin *p = plugin_list; p != NULL; p = p->next){
766
841
      fprintf(stderr, "Plugin: %s has %d arguments\n",
767
842
              p->name ? p->name : "Global", p->argc - 1);
768
843
      for(char **a = p->argv; *a != NULL; a++){
777
852
  
778
853
  if(getuid() == 0){
779
854
    /* Work around Debian bug #633582:
780
 
       <http://bugs.debian.org/633582> */
 
855
       <https://bugs.debian.org/633582> */
781
856
    int plugindir_fd = open(/* plugindir or */ PDIR, O_RDONLY);
782
857
    if(plugindir_fd == -1){
783
858
      if(errno != ENOENT){
795
870
          }
796
871
        }
797
872
      }
798
 
      TEMP_FAILURE_RETRY(close(plugindir_fd));
 
873
      close(plugindir_fd);
 
874
    }
 
875
 
 
876
    /* Work around Debian bug #981302
 
877
       <https://bugs.debian.org/981302> */
 
878
    if(lstat("/dev/fd", &st) != 0 and errno == ENOENT){
 
879
      ret = symlink("/proc/self/fd", "/dev/fd");
 
880
      if(ret == -1){
 
881
        error(0, errno, "Failed to create /dev/fd symlink");
 
882
      }
799
883
    }
800
884
  }
801
885
  
829
913
    ret = set_cloexec_flag(dir_fd);
830
914
    if(ret < 0){
831
915
      error(0, errno, "set_cloexec_flag");
832
 
      TEMP_FAILURE_RETRY(close(dir_fd));
833
916
      exitstatus = EX_OSERR;
834
917
      goto fallback;
835
918
    }
861
944
    return 1;
862
945
  }
863
946
  
864
 
#ifdef __GLIBC__
865
 
#if __GLIBC_PREREQ(2, 15)
866
947
  int numplugins = scandirat(dir_fd, ".", &direntries, good_name,
867
948
                             alphasort);
868
 
#else  /* not __GLIBC_PREREQ(2, 15) */
869
 
  int numplugins = scandir(plugindir != NULL ? plugindir : PDIR,
870
 
                           &direntries, good_name, alphasort);
871
 
#endif  /* not __GLIBC_PREREQ(2, 15) */
872
 
#else   /* not __GLIBC__ */
873
 
  int numplugins = scandir(plugindir != NULL ? plugindir : PDIR,
874
 
                           &direntries, good_name, alphasort);
875
 
#endif  /* not __GLIBC__ */
876
949
  if(numplugins == -1){
877
950
    error(0, errno, "Could not scan plugin dir");
878
 
    TEMP_FAILURE_RETRY(close(dir_fd));
 
951
    direntries = NULL;
879
952
    exitstatus = EX_OSERR;
880
953
    goto fallback;
881
954
  }
888
961
    int plugin_fd = openat(dir_fd, direntries[i]->d_name, O_RDONLY);
889
962
    if(plugin_fd == -1){
890
963
      error(0, errno, "Could not open plugin");
 
964
      free(direntries[i]);
891
965
      continue;
892
966
    }
893
967
    ret = (int)TEMP_FAILURE_RETRY(fstat(plugin_fd, &st));
894
968
    if(ret == -1){
895
969
      error(0, errno, "stat");
896
 
      TEMP_FAILURE_RETRY(close(plugin_fd));
 
970
      close(plugin_fd);
 
971
      free(direntries[i]);
897
972
      continue;
898
973
    }
899
974
    
907
982
                plugindir != NULL ? plugindir : PDIR,
908
983
                direntries[i]->d_name);
909
984
      }
910
 
      TEMP_FAILURE_RETRY(close(plugin_fd));
 
985
      close(plugin_fd);
 
986
      free(direntries[i]);
911
987
      continue;
912
988
    }
913
989
    
914
990
    plugin *p = getplugin(direntries[i]->d_name);
915
991
    if(p == NULL){
916
992
      error(0, errno, "getplugin");
917
 
      TEMP_FAILURE_RETRY(close(plugin_fd));
 
993
      close(plugin_fd);
 
994
      free(direntries[i]);
918
995
      continue;
919
996
    }
920
997
    if(p->disabled){
922
999
        fprintf(stderr, "Ignoring disabled plugin \"%s\"\n",
923
1000
                direntries[i]->d_name);
924
1001
      }
925
 
      TEMP_FAILURE_RETRY(close(plugin_fd));
 
1002
      close(plugin_fd);
 
1003
      free(direntries[i]);
926
1004
      continue;
927
1005
    }
928
1006
    {
961
1039
    if(ret == -1){
962
1040
      error(0, errno, "pipe");
963
1041
      exitstatus = EX_OSERR;
 
1042
      free(direntries[i]);
964
1043
      goto fallback;
965
1044
    }
966
1045
    if(pipefd[0] >= FD_SETSIZE){
967
1046
      fprintf(stderr, "pipe()[0] (%d) >= FD_SETSIZE (%d)", pipefd[0],
968
1047
              FD_SETSIZE);
969
 
      TEMP_FAILURE_RETRY(close(pipefd[0]));
970
 
      TEMP_FAILURE_RETRY(close(pipefd[1]));
 
1048
      close(pipefd[0]);
 
1049
      close(pipefd[1]);
971
1050
      exitstatus = EX_OSERR;
 
1051
      free(direntries[i]);
972
1052
      goto fallback;
973
1053
    }
974
1054
#ifndef O_CLOEXEC
976
1056
    ret = set_cloexec_flag(pipefd[0]);
977
1057
    if(ret < 0){
978
1058
      error(0, errno, "set_cloexec_flag");
979
 
      TEMP_FAILURE_RETRY(close(pipefd[0]));
980
 
      TEMP_FAILURE_RETRY(close(pipefd[1]));
 
1059
      close(pipefd[0]);
 
1060
      close(pipefd[1]);
981
1061
      exitstatus = EX_OSERR;
 
1062
      free(direntries[i]);
982
1063
      goto fallback;
983
1064
    }
984
1065
    ret = set_cloexec_flag(pipefd[1]);
985
1066
    if(ret < 0){
986
1067
      error(0, errno, "set_cloexec_flag");
987
 
      TEMP_FAILURE_RETRY(close(pipefd[0]));
988
 
      TEMP_FAILURE_RETRY(close(pipefd[1]));
 
1068
      close(pipefd[0]);
 
1069
      close(pipefd[1]);
989
1070
      exitstatus = EX_OSERR;
 
1071
      free(direntries[i]);
990
1072
      goto fallback;
991
1073
    }
992
1074
#endif  /* not O_CLOEXEC */
997
1079
    if(ret < 0){
998
1080
      error(0, errno, "sigprocmask");
999
1081
      exitstatus = EX_OSERR;
 
1082
      free(direntries[i]);
1000
1083
      goto fallback;
1001
1084
    }
1002
1085
    /* Starting a new process to be watched */
1008
1091
      error(0, errno, "fork");
1009
1092
      TEMP_FAILURE_RETRY(sigprocmask(SIG_UNBLOCK,
1010
1093
                                     &sigchld_action.sa_mask, NULL));
1011
 
      TEMP_FAILURE_RETRY(close(pipefd[0]));
1012
 
      TEMP_FAILURE_RETRY(close(pipefd[1]));
 
1094
      close(pipefd[0]);
 
1095
      close(pipefd[1]);
1013
1096
      exitstatus = EX_OSERR;
 
1097
      free(direntries[i]);
1014
1098
      goto fallback;
1015
1099
    }
1016
1100
    if(pid == 0){
1042
1126
      /* no return */
1043
1127
    }
1044
1128
    /* Parent process */
1045
 
    TEMP_FAILURE_RETRY(close(pipefd[1])); /* Close unused write end of
1046
 
                                             pipe */
1047
 
    TEMP_FAILURE_RETRY(close(plugin_fd));
 
1129
    close(pipefd[1]);           /* Close unused write end of pipe */
 
1130
    close(plugin_fd);
1048
1131
    plugin *new_plugin = getplugin(direntries[i]->d_name);
1049
1132
    if(new_plugin == NULL){
1050
1133
      error(0, errno, "getplugin");
1055
1138
        error(0, errno, "sigprocmask");
1056
1139
      }
1057
1140
      exitstatus = EX_OSERR;
 
1141
      free(direntries[i]);
1058
1142
      goto fallback;
1059
1143
    }
 
1144
    free(direntries[i]);
1060
1145
    
1061
1146
    new_plugin->pid = pid;
1062
1147
    new_plugin->fd = pipefd[0];
1063
 
    
 
1148
 
 
1149
    if(debug){
 
1150
      fprintf(stderr, "Plugin %s started (PID %" PRIdMAX ")\n",
 
1151
              new_plugin->name, (intmax_t) (new_plugin->pid));
 
1152
    }
 
1153
 
1064
1154
    /* Unblock SIGCHLD so signal handler can be run if this process
1065
1155
       has already completed */
1066
1156
    ret = (int)TEMP_FAILURE_RETRY(sigprocmask(SIG_UNBLOCK,
1072
1162
      goto fallback;
1073
1163
    }
1074
1164
    
1075
 
#if defined (__GNUC__) and defined (__GLIBC__)
1076
 
#if not __GLIBC_PREREQ(2, 16)
1077
 
#pragma GCC diagnostic push
1078
 
#pragma GCC diagnostic ignored "-Wsign-conversion"
1079
 
#endif
1080
 
#endif
1081
 
    FD_SET(new_plugin->fd, &rfds_all); /* Spurious warning from
1082
 
                                          -Wconversion in GNU libc
1083
 
                                          before 2.16 */
1084
 
#if defined (__GNUC__) and defined (__GLIBC__)
1085
 
#if not __GLIBC_PREREQ(2, 16)
1086
 
#pragma GCC diagnostic pop
1087
 
#endif
1088
 
#endif
 
1165
    FD_SET(new_plugin->fd, &rfds_all);
1089
1166
    
1090
1167
    if(maxfd < new_plugin->fd){
1091
1168
      maxfd = new_plugin->fd;
1092
1169
    }
1093
1170
  }
1094
1171
  
1095
 
  TEMP_FAILURE_RETRY(close(dir_fd));
 
1172
  free(direntries);
 
1173
  direntries = NULL;
 
1174
  close(dir_fd);
 
1175
  dir_fd = -1;
1096
1176
  free_plugin(getplugin(NULL));
1097
1177
  
1098
1178
  for(plugin *p = plugin_list; p != NULL; p = p->next){
1137
1217
                      (intmax_t) (proc->pid),
1138
1218
                      WTERMSIG(proc->status),
1139
1219
                      strsignal(WTERMSIG(proc->status)));
1140
 
            } else if(WCOREDUMP(proc->status)){
1141
 
              fprintf(stderr, "Plugin %s [%" PRIdMAX "] dumped"
1142
 
                      " core\n", proc->name, (intmax_t) (proc->pid));
1143
1220
            }
1144
1221
          }
1145
1222
          
1146
1223
          /* Remove the plugin */
1147
 
#if defined (__GNUC__) and defined (__GLIBC__)
1148
 
#if not __GLIBC_PREREQ(2, 16)
1149
 
#pragma GCC diagnostic push
1150
 
#pragma GCC diagnostic ignored "-Wsign-conversion"
1151
 
#endif
1152
 
#endif
1153
 
          FD_CLR(proc->fd, &rfds_all); /* Spurious warning from
1154
 
                                          -Wconversion in GNU libc
1155
 
                                          before 2.16 */
1156
 
#if defined (__GNUC__) and defined (__GLIBC__)
1157
 
#if not __GLIBC_PREREQ(2, 16)
1158
 
#pragma GCC diagnostic pop
1159
 
#endif
1160
 
#endif
 
1224
          FD_CLR(proc->fd, &rfds_all);
1161
1225
          
1162
1226
          /* Block signal while modifying process_list */
1163
1227
          ret = (int)TEMP_FAILURE_RETRY(sigprocmask
1203
1267
      }
1204
1268
      
1205
1269
      /* This process has not completed.  Does it have any output? */
1206
 
#if defined (__GNUC__) and defined (__GLIBC__)
1207
 
#if not __GLIBC_PREREQ(2, 16)
1208
 
#pragma GCC diagnostic push
1209
 
#pragma GCC diagnostic ignored "-Wsign-conversion"
1210
 
#endif
1211
 
#endif
1212
 
      if(proc->eof or not FD_ISSET(proc->fd, &rfds)){ /* Spurious
1213
 
                                                         warning from
1214
 
                                                         -Wconversion
1215
 
                                                         in GNU libc
1216
 
                                                         before
1217
 
                                                         2.16 */
1218
 
#if defined (__GNUC__) and defined (__GLIBC__)
1219
 
#if not __GLIBC_PREREQ(2, 16)
1220
 
#pragma GCC diagnostic pop
1221
 
#endif
1222
 
#endif
 
1270
      if(proc->eof or not FD_ISSET(proc->fd, &rfds)){
1223
1271
        /* This process had nothing to say at this time */
1224
1272
        proc = proc->next;
1225
1273
        continue;
1292
1340
    free(custom_argv);
1293
1341
  }
1294
1342
  
 
1343
  free(direntries);
 
1344
  
1295
1345
  if(dir_fd != -1){
1296
 
    TEMP_FAILURE_RETRY(close(dir_fd));
 
1346
    close(dir_fd);
1297
1347
  }
1298
1348
  
1299
1349
  /* Kill the processes */
1319
1369
  free_plugin_list();
1320
1370
  
1321
1371
  free(plugindir);
 
1372
  free(pluginhelperdir);
1322
1373
  free(argfile);
1323
1374
  
1324
1375
  return exitstatus;