25
25
#define _GNU_SOURCE             /* TEMP_FAILURE_RETRY(), getline(),
 
27
27
#include <stddef.h>             /* size_t, NULL */
 
28
28
#include <stdlib.h>             /* malloc(), exit(), EXIT_SUCCESS,
 
30
30
#include <stdbool.h>            /* bool, true, false */
 
31
31
#include <stdio.h>              /* fileno(), fprintf(),
 
32
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(),
 
 
33
#include <sys/types.h>          /* DIR, fdopendir(), fstat(), struct
 
 
34
                                   stat, waitpid(), WIFEXITED(),
 
 
35
                                   WEXITSTATUS(), wait(), pid_t,
 
 
36
                                   uid_t, gid_t, getuid(), getgid(),
 
37
38
#include <sys/select.h>         /* fd_set, select(), FD_ZERO(),
 
38
39
                                   FD_SET(), FD_ISSET(), FD_CLR */
 
39
40
#include <sys/wait.h>           /* wait(), waitpid(), WIFEXITED(),
 
 
42
43
#include <sys/stat.h>           /* struct stat, fstat(), S_ISREG() */
 
43
44
#include <iso646.h>             /* and, or, not */
 
44
 
#include <dirent.h>             /* struct dirent, scandirat() */
 
 
45
#include <dirent.h>             /* DIR, struct dirent, fdopendir(),
 
 
46
                                   readdir(), closedir(), dirfd() */
 
45
47
#include <unistd.h>             /* fcntl(), F_GETFD, F_SETFD,
 
46
48
                                   FD_CLOEXEC, write(), STDOUT_FILENO,
 
47
49
                                   struct stat, fstat(), close(),
 
48
50
                                   setgid(), setuid(), S_ISREG(),
 
49
 
                                   faccessat() pipe2(), fork(),
 
 
51
                                   faccessat() pipe(), fork(),
 
50
52
                                   _exit(), dup2(), fexecve(), read()
 
52
54
#include <fcntl.h>              /* fcntl(), F_GETFD, F_SETFD,
 
53
 
                                   FD_CLOEXEC, openat(), scandirat(),
 
 
55
                                   FD_CLOEXEC, openat() */
 
55
56
#include <string.h>             /* strsep, strlen(), strsignal(),
 
56
57
                                   strcmp(), strncmp() */
 
57
58
#include <errno.h>              /* errno */
 
 
778
 
    char *pluginhelperenv;
 
780
 
    ret = asprintf(&pluginhelperenv, "MANDOSPLUGINHELPERDIR=%s",
 
781
 
                   pluginhelperdir != NULL ? pluginhelperdir : PHDIR);
 
783
 
      bret = add_environment(getplugin(NULL), pluginhelperenv, true);
 
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);
 
791
 
      free(pluginhelperenv);
 
796
765
    for(plugin *p = plugin_list; p != NULL; p=p->next){
 
797
766
      fprintf(stderr, "Plugin: %s has %d arguments\n",
 
 
860
829
    ret = set_cloexec_flag(dir_fd);
 
862
831
      error(0, errno, "set_cloexec_flag");
 
 
832
      TEMP_FAILURE_RETRY(close(dir_fd));
 
863
833
      exitstatus = EX_OSERR;
 
866
836
#endif  /* O_CLOEXEC */
 
 
838
    dir = fdopendir(dir_fd);
 
 
840
      error(0, errno, "Could not open plugin dir");
 
 
841
      TEMP_FAILURE_RETRY(close(dir_fd));
 
 
842
      exitstatus = EX_OSERR;
 
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 };
 
 
849
  /* Read and execute any executable in the plugin directory*/
 
 
852
      dirst = readdir(dir);
 
 
853
    } while(dirst == NULL and errno == EINTR);
 
 
855
    /* All directory entries have been processed */
 
 
858
        error(0, errno, "readdir");
 
 
859
        exitstatus = EX_IOERR;
 
 
865
    /* Ignore dotfiles, backup files and other junk */
 
 
867
      bool bad_name = false;
 
 
868
      const char * const patterns[] = { ".*", "#*#", "*~",
 
 
869
                                        "*.dpkg-new", "*.dpkg-old",
 
 
870
                                        "*.dpkg-bak", "*.dpkg-divert",
 
874
873
#pragma GCC diagnostic push
 
875
874
#pragma GCC diagnostic ignored "-Wcast-qual"
 
877
 
    for(const char **pat = (const char **)patterns;
 
878
 
        *pat != NULL; pat++){
 
 
876
      for(const char **pat = (const char **)patterns;
 
 
877
          *pat != NULL; pat++){
 
880
879
#pragma GCC diagnostic pop
 
882
 
      if(fnmatch(*pat, dirent->d_name, FNM_FILE_NAME | FNM_PERIOD)
 
 
881
        if(fnmatch(*pat, dirst->d_name,
 
 
882
                   FNM_FILE_NAME | FNM_PERIOD) != FNM_NOMATCH){
 
885
884
            fprintf(stderr, "Ignoring plugin dir entry \"%s\""
 
886
 
                    " matching pattern %s\n", dirent->d_name, *pat);
 
 
885
                    " matching pattern %s\n", dirst->d_name, *pat);
 
894
 
  int numplugins = scandirat(dir_fd, ".", &direntries, good_name,
 
896
 
  if(numplugins == -1){
 
897
 
    error(0, errno, "Could not scan plugin dir");
 
899
 
    exitstatus = EX_OSERR;
 
905
 
  /* Read and execute any executable in the plugin directory*/
 
906
 
  for(int i = 0; i < numplugins; i++){
 
908
 
    int plugin_fd = openat(dir_fd, direntries[i]->d_name, O_RDONLY);
 
 
896
    int plugin_fd = openat(dir_fd, dirst->d_name, O_RDONLY |
 
 
899
#else  /* not O_CLOEXEC */
 
 
901
#endif  /* not O_CLOEXEC */
 
909
903
    if(plugin_fd == -1){
 
910
904
      error(0, errno, "Could not open plugin");
 
 
908
  /* Set the FD_CLOEXEC flag on the plugin FD */
 
 
909
    ret = set_cloexec_flag(plugin_fd);
 
 
911
      error(0, errno, "set_cloexec_flag");
 
 
912
      TEMP_FAILURE_RETRY(close(plugin_fd));
 
 
915
#endif  /* O_CLOEXEC */
 
914
916
    ret = (int)TEMP_FAILURE_RETRY(fstat(plugin_fd, &st));
 
916
918
      error(0, errno, "stat");
 
 
919
      TEMP_FAILURE_RETRY(close(plugin_fd));
 
922
923
    /* Ignore non-executable files */
 
923
924
    if(not S_ISREG(st.st_mode)
 
924
 
       or (TEMP_FAILURE_RETRY(faccessat(dir_fd, direntries[i]->d_name,
 
 
925
       or (TEMP_FAILURE_RETRY(faccessat(dir_fd, dirst->d_name, X_OK,
 
927
928
        fprintf(stderr, "Ignoring plugin dir entry \"%s/%s\""
 
928
929
                " with bad type or mode\n",
 
929
 
                plugindir != NULL ? plugindir : PDIR,
 
930
 
                direntries[i]->d_name);
 
 
930
                plugindir != NULL ? plugindir : PDIR, dirst->d_name);
 
 
932
      TEMP_FAILURE_RETRY(close(plugin_fd));
 
937
 
    plugin *p = getplugin(direntries[i]->d_name);
 
 
936
    plugin *p = getplugin(dirst->d_name);
 
939
938
      error(0, errno, "getplugin");
 
 
939
      TEMP_FAILURE_RETRY(close(plugin_fd));
 
946
944
        fprintf(stderr, "Ignoring disabled plugin \"%s\"\n",
 
947
 
                direntries[i]->d_name);
 
 
947
      TEMP_FAILURE_RETRY(close(plugin_fd));
 
 
982
978
    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 */
 
987
980
      error(0, errno, "pipe");
 
988
981
      exitstatus = EX_OSERR;
 
992
 
    if(pipefd[0] >= FD_SETSIZE){
 
993
 
      fprintf(stderr, "pipe()[0] (%d) >= FD_SETSIZE (%d)", pipefd[0],
 
997
 
      exitstatus = EX_OSERR;
 
1002
984
    /* Ask OS to automatic close the pipe on exec */
 
1003
985
    ret = set_cloexec_flag(pipefd[0]);
 
1005
987
      error(0, errno, "set_cloexec_flag");
 
1008
988
      exitstatus = EX_OSERR;
 
1009
 
      free(direntries[i]);
 
1012
991
    ret = set_cloexec_flag(pipefd[1]);
 
1014
993
      error(0, errno, "set_cloexec_flag");
 
1017
994
      exitstatus = EX_OSERR;
 
1018
 
      free(direntries[i]);
 
1021
 
#endif  /* not O_CLOEXEC */
 
1022
997
    /* Block SIGCHLD until process is safely in process list */
 
1023
998
    ret = (int)TEMP_FAILURE_RETRY(sigprocmask(SIG_BLOCK,
 
1024
999
                                              &sigchld_action.sa_mask,
 
 
1063
1032
        _exit(EX_OSERR);
 
 
1036
        /* If dir has no file descriptor, we could not set FD_CLOEXEC
 
 
1037
           above and must now close it manually here. */
 
1066
1040
      if(fexecve(plugin_fd, p->argv,
 
1067
1041
                (p->environ[0] != NULL) ? p->environ : environ) < 0){
 
1068
1042
        error(0, errno, "fexecve for %s/%s",
 
1069
 
              plugindir != NULL ? plugindir : PDIR,
 
1070
 
              direntries[i]->d_name);
 
 
1043
              plugindir != NULL ? plugindir : PDIR, dirst->d_name);
 
1071
1044
        _exit(EX_OSERR);
 
1073
1046
      /* no return */
 
1075
1048
    /* Parent process */
 
1076
 
    close(pipefd[1]);           /* Close unused write end of pipe */
 
1078
 
    plugin *new_plugin = getplugin(direntries[i]->d_name);
 
 
1049
    TEMP_FAILURE_RETRY(close(pipefd[1])); /* Close unused write end of
 
 
1051
    TEMP_FAILURE_RETRY(close(plugin_fd));
 
 
1052
    plugin *new_plugin = getplugin(dirst->d_name);
 
1079
1053
    if(new_plugin == NULL){
 
1080
1054
      error(0, errno, "getplugin");
 
1081
1055
      ret = (int)(TEMP_FAILURE_RETRY
 
 
1107
 
    FD_SET(new_plugin->fd, &rfds_all);
 
 
1079
#if defined (__GNUC__) and defined (__GLIBC__)
 
 
1080
#if not __GLIBC_PREREQ(2, 16)
 
 
1081
#pragma GCC diagnostic push
 
 
1082
#pragma GCC diagnostic ignored "-Wsign-conversion"
 
 
1085
    FD_SET(new_plugin->fd, &rfds_all); /* Spurious warning from
 
 
1086
                                          -Wconversion in GNU libc
 
 
1088
#if defined (__GNUC__) and defined (__GLIBC__)
 
 
1089
#if not __GLIBC_PREREQ(2, 16)
 
 
1090
#pragma GCC diagnostic pop
 
1109
1094
    if(maxfd < new_plugin->fd){
 
1110
1095
      maxfd = new_plugin->fd;
 
 
1099
  TEMP_FAILURE_RETRY(closedir(dir));
 
1118
1101
  free_plugin(getplugin(NULL));
 
1120
1103
  for(plugin *p = plugin_list; p != NULL; p = p->next){