/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: 2008-08-29 05:53:59 UTC
  • Revision ID: teddy@fukt.bsnet.se-20080829055359-wkdasnyxtylmnxus
* mandos.xml (EXAMPLE): Replaced all occurences of command name with
                        "&COMMANDNAME;".

* plugins.d/password-prompt.c (main): Improved some documentation
                                      strings.  Do perror() of
                                      tcgetattr() fails.  Add debug
                                      output if interrupted by signal.
                                      Loop over write() instead of
                                      using fwrite() when outputting
                                      password.  Add debug output if
                                      getline() returns 0, unless it
                                      was caused by a signal.  Add
                                      exit status code to debug
                                      output.

* plugins.d/password-prompt.xml: Changed all single quotes to double
                                 quotes for consistency.  Removed
                                 <?xml-stylesheet>.
  (ENTITY TIMESTAMP): New.  Automatically updated by Emacs time-stamp
                      by using Emacs local variables.
  (/refentry/refentryinfo/title): Changed to "Mandos Manual".
  (/refentry/refentryinfo/productname): Changed to "Mandos".
  (/refentry/refentryinfo/date): New; set to "&TIMESTAMP;".
  (/refentry/refentryinfo/copyright): Split copyright holders.
  (/refentry/refnamediv/refpurpose): Improved wording.
  (SYNOPSIS): Fix to use correct markup.  Add short options.
  (DESCRIPTION, OPTIONS): Improved wording.
  (OPTIONS): Improved wording.  Use more correct markup.  Document
             short options.
  (EXIT STATUS): Add text.
  (ENVIRONMENT): Document use of "cryptsource" and "crypttarget".
  (FILES): REMOVED.
  (BUGS): Add text.
  (EXAMPLE): Added some examples.
  (SECURITY): Added text.
  (SEE ALSO): Remove reference to mandos(8).  Add reference to
              crypttab(5).

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 © 2007-2008 Teddy Hogeborn & Björn Påhlsson
7
6
 * 
8
7
 * This program is free software: you can redistribute it and/or
9
8
 * modify it under the terms of the GNU General Public License as
28
27
#include <stdlib.h>             /* malloc(), exit(), EXIT_FAILURE,
29
28
                                   EXIT_SUCCESS, realloc() */
30
29
#include <stdbool.h>            /* bool, true, false */
31
 
#include <stdio.h>              /* perror, fileno(), fprintf(),
32
 
                                   stderr, STDOUT_FILENO */
 
30
#include <stdio.h>              /* perror, popen(), fileno(),
 
31
                                   fprintf(), stderr, STDOUT_FILENO */
33
32
#include <sys/types.h>          /* DIR, opendir(), stat(), struct
34
33
                                   stat, waitpid(), WIFEXITED(),
35
34
                                   WEXITSTATUS(), wait(), pid_t,
47
46
                                   fcntl(), setuid(), setgid(),
48
47
                                   F_GETFD, F_SETFD, FD_CLOEXEC,
49
48
                                   access(), pipe(), fork(), close()
50
 
                                   dup2(), STDOUT_FILENO, _exit(),
 
49
                                   dup2, STDOUT_FILENO, _exit(),
51
50
                                   execv(), write(), read(),
52
51
                                   close() */
53
52
#include <fcntl.h>              /* fcntl(), F_GETFD, F_SETFD,
70
69
#define PDIR "/lib/mandos/plugins.d"
71
70
#define AFILE "/conf/conf.d/mandos/plugin-runner.conf"
72
71
 
73
 
const char *argp_program_version = "plugin-runner " VERSION;
 
72
const char *argp_program_version = "plugin-runner 1.0";
74
73
const char *argp_program_bug_address = "<mandos@fukt.bsnet.se>";
75
74
 
76
 
typedef struct plugin{
77
 
  char *name;                   /* can be NULL or any plugin name */
78
 
  char **argv;
79
 
  int argc;
80
 
  char **environ;
81
 
  int envc;
82
 
  bool disabled;
 
75
struct process;
83
76
 
84
 
  /* Variables used for running processes*/
 
77
typedef struct process{
85
78
  pid_t pid;
86
79
  int fd;
87
80
  char *buffer;
90
83
  bool eof;
91
84
  volatile bool completed;
92
85
  volatile int status;
 
86
  struct process *next;
 
87
} process;
 
88
 
 
89
typedef struct plugin{
 
90
  char *name;                   /* can be NULL or any plugin name */
 
91
  char **argv;
 
92
  int argc;
 
93
  char **environ;
 
94
  int envc;
 
95
  bool disabled;
93
96
  struct plugin *next;
94
97
} plugin;
95
98
 
96
 
static plugin *plugin_list = NULL;
97
 
 
98
 
/* Gets an existing plugin based on name,
99
 
   or if none is found, creates a new one */
100
 
static plugin *getplugin(char *name){
101
 
  /* Check for exiting plugin with that name */
102
 
  for (plugin *p = plugin_list; p != NULL; p = p->next){
 
99
static plugin *getplugin(char *name, plugin **plugin_list){
 
100
  for (plugin *p = *plugin_list; p != NULL; p = p->next){
103
101
    if ((p->name == name)
104
102
        or (p->name and name and (strcmp(p->name, name) == 0))){
105
103
      return p;
120
118
  
121
119
  *new_plugin = (plugin) { .name = copy_name,
122
120
                           .argc = 1,
 
121
                           .envc = 0,
123
122
                           .disabled = false,
124
 
                           .next = plugin_list };
 
123
                           .next = *plugin_list };
125
124
  
126
125
  new_plugin->argv = malloc(sizeof(char *) * 2);
127
126
  if (new_plugin->argv == NULL){
131
130
  }
132
131
  new_plugin->argv[0] = copy_name;
133
132
  new_plugin->argv[1] = NULL;
134
 
  
 
133
 
135
134
  new_plugin->environ = malloc(sizeof(char *));
136
135
  if(new_plugin->environ == NULL){
137
136
    free(copy_name);
140
139
    return NULL;
141
140
  }
142
141
  new_plugin->environ[0] = NULL;
143
 
  
144
142
  /* Append the new plugin to the list */
145
 
  plugin_list = new_plugin;
 
143
  *plugin_list = new_plugin;
146
144
  return new_plugin;
147
145
}
148
146
 
178
176
}
179
177
 
180
178
/* Add to a plugin's environment */
181
 
static bool add_environment(plugin *p, const char *def, bool replace){
 
179
static bool add_environment(plugin *p, const char *def){
182
180
  if(p == NULL){
183
181
    return false;
184
182
  }
185
 
  /* namelen = length of name of environment variable */
186
 
  size_t namelen = (size_t)(strchrnul(def, '=') - def);
187
 
  /* Search for this environment variable */
188
 
  for(char **e = p->environ; *e != NULL; e++){
189
 
    if(strncmp(*e, def, namelen + 1) == 0){
190
 
      /* It already exists */
191
 
      if(replace){
192
 
        char *new = realloc(*e, strlen(def) + 1);
193
 
        if(new == NULL){
194
 
          return false;
195
 
        }
196
 
        *e = new;
197
 
        strcpy(*e, def);
198
 
      }
199
 
      return true;
200
 
    }
201
 
  }
202
183
  return add_to_char_array(def, &(p->environ), &(p->envc));
203
184
}
204
185
 
 
186
 
205
187
/*
206
188
 * Based on the example in the GNU LibC manual chapter 13.13 "File
207
189
 * Descriptor Flags".
208
190
 * *Note File Descriptor Flags:(libc)Descriptor Flags.
209
191
 */
210
 
static int set_cloexec_flag(int fd){
 
192
static int set_cloexec_flag(int fd)
 
193
{
211
194
  int ret = fcntl(fd, F_GETFD, 0);
212
195
  /* If reading the flags failed, return error indication now. */
213
196
  if(ret < 0){
217
200
  return fcntl(fd, F_SETFD, ret | FD_CLOEXEC);
218
201
}
219
202
 
 
203
process *process_list = NULL;
220
204
 
221
205
/* Mark processes as completed when they exit, and save their exit
222
206
   status. */
223
 
static void handle_sigchld(__attribute__((unused)) int sig){
 
207
void handle_sigchld(__attribute__((unused)) int sig){
224
208
  while(true){
225
 
    plugin *proc = plugin_list;
 
209
    process *proc = process_list;
226
210
    int status;
227
211
    pid_t pid = waitpid(-1, &status, WNOHANG);
228
212
    if(pid == 0){
236
220
      /* No child processes */
237
221
      break;
238
222
    }
239
 
    
 
223
 
240
224
    /* A child exited, find it in process_list */
241
225
    while(proc != NULL and proc->pid != pid){
242
226
      proc = proc->next;
250
234
  }
251
235
}
252
236
 
253
 
/* Prints out a password to stdout */
254
 
static bool print_out_password(const char *buffer, size_t length){
 
237
bool print_out_password(const char *buffer, size_t length){
255
238
  ssize_t ret;
 
239
  if(length>0 and buffer[length-1] == '\n'){
 
240
    length--;
 
241
  }
256
242
  for(size_t written = 0; written < length; written += (size_t)ret){
257
243
    ret = TEMP_FAILURE_RETRY(write(STDOUT_FILENO, buffer + written,
258
244
                                   length - written));
263
249
  return true;
264
250
}
265
251
 
266
 
/* Removes and free a plugin from the plugin list */
267
 
static void free_plugin(plugin *plugin_node){
268
 
  
269
 
  for(char **arg = plugin_node->argv; *arg != NULL; arg++){
270
 
    free(*arg);
271
 
  }
272
 
  free(plugin_node->argv);
273
 
  for(char **env = plugin_node->environ; *env != NULL; env++){
274
 
    free(*env);
275
 
  }
276
 
  free(plugin_node->environ);
277
 
  free(plugin_node->buffer);
278
 
 
279
 
  /* Removes the plugin from the singly-linked list */
280
 
  if(plugin_node == plugin_list){
281
 
    /* First one - simple */
282
 
    plugin_list = plugin_list->next;
283
 
  } else {
284
 
    /* Second one or later */
285
 
    for(plugin *p = plugin_list; p != NULL; p = p->next){
286
 
      if(p->next == plugin_node){
287
 
        p->next = plugin_node->next;
288
 
        break;
289
 
      }
290
 
    }
291
 
  }
292
 
  
293
 
  free(plugin_node);
294
 
}
295
 
 
296
 
static void free_plugin_list(void){
297
 
  while(plugin_list != NULL){
298
 
    free_plugin(plugin_list);
 
252
static void free_plugin_list(plugin *plugin_list){
 
253
  for(plugin *next; plugin_list != NULL; plugin_list = next){
 
254
    next = plugin_list->next;
 
255
    for(char **arg = plugin_list->argv; *arg != NULL; arg++){
 
256
      free(*arg);
 
257
    }
 
258
    free(plugin_list->argv);
 
259
    for(char **env = plugin_list->environ; *env != NULL; env++){
 
260
      free(*env);
 
261
    }
 
262
    free(plugin_list->environ);
 
263
    free(plugin_list);
299
264
  }
300
265
}
301
266
 
339
304
    { .name = "global-options", .key = 'g',
340
305
      .arg = "OPTION[,OPTION[,...]]",
341
306
      .doc = "Options passed to all plugins" },
342
 
    { .name = "global-env", .key = 'G',
 
307
    { .name = "global-envs", .key = 'e',
343
308
      .arg = "VAR=value",
344
309
      .doc = "Environment variable passed to all plugins" },
345
310
    { .name = "options-for", .key = 'o',
346
311
      .arg = "PLUGIN:OPTION[,OPTION[,...]]",
347
312
      .doc = "Options passed only to specified plugin" },
348
 
    { .name = "env-for", .key = 'E',
 
313
    { .name = "envs-for", .key = 'f',
349
314
      .arg = "PLUGIN:ENV=value",
350
315
      .doc = "Environment variable passed to specified plugin" },
351
316
    { .name = "disable", .key = 'd',
352
317
      .arg = "PLUGIN",
353
318
      .doc = "Disable a specific plugin", .group = 1 },
354
 
    { .name = "enable", .key = 'e',
355
 
      .arg = "PLUGIN",
356
 
      .doc = "Enable a specific plugin", .group = 1 },
357
319
    { .name = "plugin-dir", .key = 128,
358
320
      .arg = "DIRECTORY",
359
321
      .doc = "Specify a different plugin directory", .group = 2 },
371
333
    { .name = NULL }
372
334
  };
373
335
  
374
 
  error_t parse_opt (int key, char *arg, __attribute__((unused))
375
 
                     struct argp_state *state) {
 
336
  error_t parse_opt (int key, char *arg, struct argp_state *state) {
 
337
    /* Get the INPUT argument from `argp_parse', which we know is a
 
338
       pointer to our plugin list pointer. */
 
339
    plugin **plugins = state->input;
376
340
    switch (key) {
377
 
    case 'g':                   /* --global-options */
 
341
    case 'g':
378
342
      if (arg != NULL){
379
343
        char *p;
380
344
        while((p = strsep(&arg, ",")) != NULL){
381
345
          if(p[0] == '\0'){
382
346
            continue;
383
347
          }
384
 
          if(not add_argument(getplugin(NULL), p)){
 
348
          if(not add_argument(getplugin(NULL, plugins), p)){
385
349
            perror("add_argument");
386
350
            return ARGP_ERR_UNKNOWN;
387
351
          }
388
352
        }
389
353
      }
390
354
      break;
391
 
    case 'G':                   /* --global-env */
 
355
    case 'e':
392
356
      if(arg == NULL){
393
357
        break;
394
358
      }
395
 
      if(not add_environment(getplugin(NULL), arg, true)){
396
 
        perror("add_environment");
 
359
      {
 
360
        char *envdef = strdup(arg);
 
361
        if(envdef == NULL){
 
362
          break;
 
363
        }
 
364
        if(not add_environment(getplugin(NULL, plugins), envdef)){
 
365
          perror("add_environment");
 
366
        }
397
367
      }
398
368
      break;
399
 
    case 'o':                   /* --options-for */
 
369
    case 'o':
400
370
      if (arg != NULL){
401
371
        char *p_name = strsep(&arg, ":");
402
 
        if(p_name[0] == '\0' or arg == NULL){
 
372
        if(p_name[0] == '\0'){
403
373
          break;
404
374
        }
405
375
        char *opt = strsep(&arg, ":");
406
 
        if(opt[0] == '\0' or opt == NULL){
 
376
        if(opt[0] == '\0'){
407
377
          break;
408
378
        }
409
 
        char *p;
410
 
        while((p = strsep(&opt, ",")) != NULL){
411
 
          if(p[0] == '\0'){
412
 
            continue;
413
 
          }
414
 
          if(not add_argument(getplugin(p_name), p)){
415
 
            perror("add_argument");
416
 
            return ARGP_ERR_UNKNOWN;
 
379
        if(opt != NULL){
 
380
          char *p;
 
381
          while((p = strsep(&opt, ",")) != NULL){
 
382
            if(p[0] == '\0'){
 
383
              continue;
 
384
            }
 
385
            if(not add_argument(getplugin(p_name, plugins), p)){
 
386
              perror("add_argument");
 
387
              return ARGP_ERR_UNKNOWN;
 
388
            }
417
389
          }
418
390
        }
419
391
      }
420
392
      break;
421
 
    case 'E':                   /* --env-for */
 
393
    case 'f':
422
394
      if(arg == NULL){
423
395
        break;
424
396
      }
427
399
        if(envdef == NULL){
428
400
          break;
429
401
        }
430
 
        *envdef = '\0';
431
 
        if(not add_environment(getplugin(arg), envdef+1, true)){
 
402
        char *p_name = strndup(arg, (size_t) (envdef-arg));
 
403
        if(p_name == NULL){
 
404
          break;
 
405
        }
 
406
        envdef++;
 
407
        if(not add_environment(getplugin(p_name, plugins), envdef)){
432
408
          perror("add_environment");
433
409
        }
434
410
      }
435
411
      break;
436
 
    case 'd':                   /* --disable */
 
412
    case 'd':
437
413
      if (arg != NULL){
438
 
        plugin *p = getplugin(arg);
 
414
        plugin *p = getplugin(arg, plugins);
439
415
        if(p == NULL){
440
416
          return ARGP_ERR_UNKNOWN;
441
417
        }
442
418
        p->disabled = true;
443
419
      }
444
420
      break;
445
 
    case 'e':                   /* --enable */
446
 
      if (arg != NULL){
447
 
        plugin *p = getplugin(arg);
448
 
        if(p == NULL){
449
 
          return ARGP_ERR_UNKNOWN;
450
 
        }
451
 
        p->disabled = false;
452
 
      }
453
 
      break;
454
 
    case 128:                   /* --plugin-dir */
455
 
      free(plugindir);
 
421
    case 128:
456
422
      plugindir = strdup(arg);
457
423
      if(plugindir == NULL){
458
424
        perror("strdup");
459
425
      }      
460
426
      break;
461
 
    case 129:                   /* --config-file */
462
 
      /* This is already done by parse_opt_config_file() */
463
 
      break;
464
 
    case 130:                   /* --userid */
 
427
    case 129:
 
428
      argfile = strdup(arg);
 
429
      if(argfile == NULL){
 
430
        perror("strdup");
 
431
      }
 
432
      break;      
 
433
    case 130:
465
434
      uid = (uid_t)strtol(arg, NULL, 10);
466
435
      break;
467
 
    case 131:                   /* --groupid */
 
436
    case 131:
468
437
      gid = (gid_t)strtol(arg, NULL, 10);
469
438
      break;
470
 
    case 132:                   /* --debug */
 
439
    case 132:
471
440
      debug = true;
472
441
      break;
473
442
    case ARGP_KEY_ARG:
474
 
      /* Cryptsetup always passes an argument, which is an empty
475
 
         string if "none" was specified in /etc/crypttab.  So if
476
 
         argument was empty, we ignore it silently. */
477
 
      if(arg[0] != '\0'){
478
 
        fprintf(stderr, "Ignoring unknown argument \"%s\"\n", arg);
479
 
      }
480
 
      break;
481
 
    case ARGP_KEY_END:
482
 
      break;
483
 
    default:
484
 
      return ARGP_ERR_UNKNOWN;
485
 
    }
486
 
    return 0;
487
 
  }
488
 
  
489
 
  /* This option parser is the same as parse_opt() above, except it
490
 
     ignores everything but the --config-file option. */
491
 
  error_t parse_opt_config_file (int key, char *arg,
492
 
                                 __attribute__((unused))
493
 
                                 struct argp_state *state) {
494
 
    switch (key) {
495
 
    case 'g':                   /* --global-options */
496
 
    case 'G':                   /* --global-env */
497
 
    case 'o':                   /* --options-for */
498
 
    case 'E':                   /* --env-for */
499
 
    case 'd':                   /* --disable */
500
 
    case 'e':                   /* --enable */
501
 
    case 128:                   /* --plugin-dir */
502
 
      break;
503
 
    case 129:                   /* --config-file */
504
 
      free(argfile);
505
 
      argfile = strdup(arg);
506
 
      if(argfile == NULL){
507
 
        perror("strdup");
508
 
      }
509
 
      break;      
510
 
    case 130:                   /* --userid */
511
 
    case 131:                   /* --groupid */
512
 
    case 132:                   /* --debug */
513
 
    case ARGP_KEY_ARG:
514
 
    case ARGP_KEY_END:
515
 
      break;
516
 
    default:
517
 
      return ARGP_ERR_UNKNOWN;
518
 
    }
519
 
    return 0;
520
 
  }
521
 
  
522
 
  struct argp argp = { .options = options,
523
 
                       .parser = parse_opt_config_file,
524
 
                       .args_doc = "",
 
443
      fprintf(stderr, "Ignoring unknown argument \"%s\"\n", arg);
 
444
      break;
 
445
    case ARGP_KEY_END:
 
446
      break;
 
447
    default:
 
448
      return ARGP_ERR_UNKNOWN;
 
449
    }
 
450
    return 0;
 
451
  }
 
452
  
 
453
  plugin *plugin_list = NULL;
 
454
  
 
455
  struct argp argp = { .options = options, .parser = parse_opt,
 
456
                       .args_doc = "[+PLUS_SEPARATED_OPTIONS]",
525
457
                       .doc = "Mandos plugin runner -- Run plugins" };
526
458
  
527
 
  /* Parse using the parse_opt_config_file in order to get the custom
528
 
     config file location, if any. */
529
 
  ret = argp_parse (&argp, argc, argv, ARGP_IN_ORDER, 0, NULL);
 
459
  ret = argp_parse (&argp, argc, argv, 0, 0, &plugin_list);
530
460
  if (ret == ARGP_ERR_UNKNOWN){
531
461
    fprintf(stderr, "Unknown error while parsing arguments\n");
532
462
    exitstatus = EXIT_FAILURE;
533
463
    goto fallback;
534
464
  }
535
 
  
536
 
  /* Reset to the normal argument parser */
537
 
  argp.parser = parse_opt;
538
 
  
539
 
  /* Open the configfile if available */
 
465
 
540
466
  if (argfile == NULL){
541
467
    conffp = fopen(AFILE, "r");
542
468
  } else {
543
469
    conffp = fopen(argfile, "r");
544
 
  }  
 
470
  }
 
471
  
545
472
  if(conffp != NULL){
546
473
    char *org_line = NULL;
547
474
    char *p, *arg, *new_arg, *line;
559
486
    }
560
487
    custom_argv[0] = argv[0];
561
488
    custom_argv[1] = NULL;
562
 
 
563
 
    /* for each line in the config file, strip whitespace and ignore
564
 
       commented text */
 
489
    
565
490
    while(true){
566
491
      sret = getline(&org_line, &size, conffp);
567
492
      if(sret == -1){
596
521
      }
597
522
    }
598
523
    free(org_line);
599
 
  } else {
 
524
  } else{
600
525
    /* Check for harmful errors and go to fallback. Other errors might
601
526
       not affect opening plugins */
602
527
    if (errno == EMFILE or errno == ENFILE or errno == ENOMEM){
605
530
      goto fallback;
606
531
    }
607
532
  }
608
 
  /* If there was any arguments from configuration file,
609
 
     pass them to parser as command arguments */
 
533
 
610
534
  if(custom_argv != NULL){
611
 
    ret = argp_parse (&argp, custom_argc, custom_argv, ARGP_IN_ORDER,
612
 
                      0, NULL);
 
535
    ret = argp_parse (&argp, custom_argc, custom_argv, 0, 0, &plugin_list);
613
536
    if (ret == ARGP_ERR_UNKNOWN){
614
537
      fprintf(stderr, "Unknown error while parsing arguments\n");
615
538
      exitstatus = EXIT_FAILURE;
617
540
    }
618
541
  }
619
542
  
620
 
  /* Parse actual command line arguments, to let them override the
621
 
     config file */
622
 
  ret = argp_parse (&argp, argc, argv, ARGP_IN_ORDER, 0, NULL);
623
 
  if (ret == ARGP_ERR_UNKNOWN){
624
 
    fprintf(stderr, "Unknown error while parsing arguments\n");
625
 
    exitstatus = EXIT_FAILURE;
626
 
    goto fallback;
627
 
  }
628
 
  
629
543
  if(debug){
630
544
    for(plugin *p = plugin_list; p != NULL; p=p->next){
631
545
      fprintf(stderr, "Plugin: %s has %d arguments\n",
640
554
    }
641
555
  }
642
556
  
643
 
  /* Strip permissions down to nobody */
644
557
  ret = setuid(uid);
645
558
  if (ret == -1){
646
559
    perror("setuid");
647
 
  }  
 
560
  }
 
561
  
648
562
  setgid(gid);
649
563
  if (ret == -1){
650
564
    perror("setgid");
651
565
  }
652
 
  
 
566
 
653
567
  if (plugindir == NULL){
654
568
    dir = opendir(PDIR);
655
569
  } else {
677
591
  
678
592
  FD_ZERO(&rfds_all);
679
593
  
680
 
  /* Read and execute any executable in the plugin directory*/
681
594
  while(true){
682
595
    dirst = readdir(dir);
683
596
    
684
 
    /* All directory entries have been processed */
 
597
    // All directory entries have been processed
685
598
    if(dirst == NULL){
686
599
      if (errno == EBADF){
687
600
        perror("readdir");
693
606
    
694
607
    d_name_len = strlen(dirst->d_name);
695
608
    
696
 
    /* Ignore dotfiles, backup files and other junk */
 
609
    // Ignore dotfiles, backup files and other junk
697
610
    {
698
611
      bool bad_name = false;
699
612
      
701
614
      
702
615
      const char const *bad_suffixes[] = { "~", "#", ".dpkg-new",
703
616
                                           ".dpkg-old",
704
 
                                           ".dpkg-bak",
705
617
                                           ".dpkg-divert", NULL };
706
618
      for(const char **pre = bad_prefixes; *pre != NULL; pre++){
707
619
        size_t pre_len = strlen(*pre);
715
627
          break;
716
628
        }
717
629
      }
 
630
      
718
631
      if(bad_name){
719
632
        continue;
720
633
      }
 
634
      
721
635
      for(const char **suf = bad_suffixes; *suf != NULL; suf++){
722
636
        size_t suf_len = strlen(*suf);
723
637
        if((d_name_len >= suf_len)
738
652
    }
739
653
 
740
654
    char *filename;
741
 
    if(plugindir == NULL){
742
 
      ret = asprintf(&filename, PDIR "/%s", dirst->d_name);
743
 
    } else {
744
 
      ret = asprintf(&filename, "%s/%s", plugindir, dirst->d_name);
745
 
    }
 
655
    ret = asprintf(&filename, "%s/%s", plugindir, dirst->d_name);
746
656
    if(ret < 0){
747
657
      perror("asprintf");
748
658
      continue;
754
664
      free(filename);
755
665
      continue;
756
666
    }
757
 
 
758
 
    /* Ignore non-executable files */
 
667
    
759
668
    if (not S_ISREG(st.st_mode) or (access(filename, X_OK) != 0)){
760
669
      if(debug){
761
670
        fprintf(stderr, "Ignoring plugin dir entry \"%s\""
764
673
      free(filename);
765
674
      continue;
766
675
    }
767
 
    
768
 
    plugin *p = getplugin(dirst->d_name);
 
676
    plugin *p = getplugin(dirst->d_name, &plugin_list);
769
677
    if(p == NULL){
770
678
      perror("getplugin");
771
679
      free(filename);
781
689
    }
782
690
    {
783
691
      /* Add global arguments to argument list for this plugin */
784
 
      plugin *g = getplugin(NULL);
 
692
      plugin *g = getplugin(NULL, &plugin_list);
785
693
      if(g != NULL){
786
694
        for(char **a = g->argv + 1; *a != NULL; a++){
787
695
          if(not add_argument(p, *a)){
790
698
        }
791
699
        /* Add global environment variables */
792
700
        for(char **e = g->environ; *e != NULL; e++){
793
 
          if(not add_environment(p, *e, false)){
 
701
          if(not add_environment(p, *e)){
794
702
            perror("add_environment");
795
703
          }
796
704
        }
801
709
       process, too. */
802
710
    if(p->environ[0] != NULL){
803
711
      for(char **e = environ; *e != NULL; e++){
804
 
        if(not add_environment(p, *e, false)){
 
712
        char *copy = strdup(*e);
 
713
        if(copy == NULL){
 
714
          perror("strdup");
 
715
          continue;
 
716
        }
 
717
        if(not add_environment(p, copy)){
805
718
          perror("add_environment");
806
719
        }
807
720
      }
814
727
      exitstatus = EXIT_FAILURE;
815
728
      goto fallback;
816
729
    }
817
 
    /* Ask OS to automatic close the pipe on exec */
818
730
    ret = set_cloexec_flag(pipefd[0]);
819
731
    if(ret < 0){
820
732
      perror("set_cloexec_flag");
834
746
      exitstatus = EXIT_FAILURE;
835
747
      goto fallback;
836
748
    }
837
 
    /* Starting a new process to be watched */
 
749
    // Starting a new process to be watched
838
750
    pid_t pid = fork();
839
751
    if(pid == -1){
840
752
      perror("fork");
848
760
        perror("sigaction");
849
761
        _exit(EXIT_FAILURE);
850
762
      }
851
 
      ret = sigprocmask(SIG_UNBLOCK, &sigchld_action.sa_mask, NULL);
 
763
      ret = sigprocmask (SIG_UNBLOCK, &sigchld_action.sa_mask, NULL);
852
764
      if(ret < 0){
853
765
        perror("sigprocmask");
854
766
        _exit(EXIT_FAILURE);
855
767
      }
856
 
      
 
768
 
857
769
      ret = dup2(pipefd[1], STDOUT_FILENO); /* replace our stdout */
858
770
      if(ret == -1){
859
771
        perror("dup2");
878
790
      }
879
791
      /* no return */
880
792
    }
881
 
    /* Parent process */
882
 
    close(pipefd[1]);           /* Close unused write end of pipe */
 
793
    /* parent process */
883
794
    free(filename);
884
 
    plugin *new_plugin = getplugin(dirst->d_name);
885
 
    if (new_plugin == NULL){
886
 
      perror("getplugin");
 
795
    close(pipefd[1]);           /* close unused write end of pipe */
 
796
    process *new_process = malloc(sizeof(process));
 
797
    if (new_process == NULL){
 
798
      perror("malloc");
887
799
      ret = sigprocmask (SIG_UNBLOCK, &sigchld_action.sa_mask, NULL);
888
800
      if(ret < 0){
889
 
        perror("sigprocmask");
 
801
        perror("sigprocmask");
890
802
      }
891
803
      exitstatus = EXIT_FAILURE;
892
804
      goto fallback;
893
805
    }
894
806
    
895
 
    new_plugin->pid = pid;
896
 
    new_plugin->fd = pipefd[0];
897
 
    
 
807
    *new_process = (struct process){ .pid = pid,
 
808
                                     .fd = pipefd[0],
 
809
                                     .next = process_list };
 
810
    // List handling
 
811
    process_list = new_process;
898
812
    /* Unblock SIGCHLD so signal handler can be run if this process
899
813
       has already completed */
900
814
    ret = sigprocmask (SIG_UNBLOCK, &sigchld_action.sa_mask, NULL);
904
818
      goto fallback;
905
819
    }
906
820
    
907
 
    FD_SET(new_plugin->fd, &rfds_all);
 
821
    FD_SET(new_process->fd, &rfds_all);
908
822
    
909
 
    if (maxfd < new_plugin->fd){
910
 
      maxfd = new_plugin->fd;
 
823
    if (maxfd < new_process->fd){
 
824
      maxfd = new_process->fd;
911
825
    }
 
826
    
912
827
  }
 
828
 
 
829
  free_plugin_list(plugin_list);
 
830
  plugin_list = NULL;
913
831
  
914
832
  closedir(dir);
915
833
  dir = NULL;
916
 
  
917
 
  for(plugin *p = plugin_list; p != NULL; p = p->next){
918
 
    if(p->pid != 0){
919
 
      break;
920
 
    }
921
 
    if(p->next == NULL){
922
 
      fprintf(stderr, "No plugin processes started. Incorrect plugin"
923
 
              " directory?\n");
924
 
      free_plugin_list();
925
 
    }
 
834
    
 
835
  if (process_list == NULL){
 
836
    fprintf(stderr, "No plugin processes started. Incorrect plugin"
 
837
            " directory?\n");
 
838
    process_list = NULL;
926
839
  }
927
 
  
928
 
  /* Main loop while running plugins exist */
929
 
  while(plugin_list){
 
840
  while(process_list){
930
841
    fd_set rfds = rfds_all;
931
842
    int select_ret = select(maxfd+1, &rfds, NULL, NULL, NULL);
932
843
    if (select_ret == -1){
936
847
    }
937
848
    /* OK, now either a process completed, or something can be read
938
849
       from one of them */
939
 
    for(plugin *proc = plugin_list; proc != NULL;){
 
850
    for(process *proc = process_list; proc ; proc = proc->next){
940
851
      /* Is this process completely done? */
941
852
      if(proc->eof and proc->completed){
942
853
        /* Only accept the plugin output if it exited cleanly */
943
854
        if(not WIFEXITED(proc->status)
944
855
           or WEXITSTATUS(proc->status) != 0){
945
856
          /* Bad exit by plugin */
946
 
 
947
857
          if(debug){
948
858
            if(WIFEXITED(proc->status)){
949
859
              fprintf(stderr, "Plugin %u exited with status %d\n",
958
868
                      (unsigned int) (proc->pid));
959
869
            }
960
870
          }
961
 
          
962
871
          /* Remove the plugin */
963
872
          FD_CLR(proc->fd, &rfds_all);
964
 
 
965
873
          /* Block signal while modifying process_list */
966
874
          ret = sigprocmask(SIG_BLOCK, &sigchld_action.sa_mask, NULL);
967
875
          if(ret < 0){
969
877
            exitstatus = EXIT_FAILURE;
970
878
            goto fallback;
971
879
          }
972
 
          
973
 
          plugin *next_plugin = proc->next;
974
 
          free_plugin(proc);
975
 
          proc = next_plugin;
976
 
          
 
880
          /* Delete this process entry from the list */
 
881
          if(process_list == proc){
 
882
            /* First one - simple */
 
883
            process_list = proc->next;
 
884
          } else {
 
885
            /* Second one or later */
 
886
            for(process *p = process_list; p != NULL; p = p->next){
 
887
              if(p->next == proc){
 
888
                p->next = proc->next;
 
889
                break;
 
890
              }
 
891
            }
 
892
          }
977
893
          /* We are done modifying process list, so unblock signal */
978
894
          ret = sigprocmask (SIG_UNBLOCK, &sigchld_action.sa_mask,
979
895
                             NULL);
980
896
          if(ret < 0){
981
897
            perror("sigprocmask");
982
 
            exitstatus = EXIT_FAILURE;
983
 
            goto fallback;
984
 
          }
985
 
          
986
 
          if(plugin_list == NULL){
987
 
            break;
988
 
          }
989
 
          
990
 
          continue;
 
898
          }
 
899
          free(proc->buffer);
 
900
          free(proc);
 
901
          /* We deleted this process from the list, so we can't go
 
902
             proc->next.  Therefore, start over from the beginning of
 
903
             the process list */
 
904
          break;
991
905
        }
992
 
        
993
906
        /* This process exited nicely, so print its buffer */
994
 
        
 
907
 
995
908
        bool bret = print_out_password(proc->buffer,
996
909
                                       proc->buffer_length);
997
910
        if(not bret){
1000
913
        }
1001
914
        goto fallback;
1002
915
      }
1003
 
      
1004
916
      /* This process has not completed.  Does it have any output? */
1005
917
      if(proc->eof or not FD_ISSET(proc->fd, &rfds)){
1006
918
        /* This process had nothing to say at this time */
1007
 
        proc = proc->next;
1008
919
        continue;
1009
920
      }
1010
921
      /* Before reading, make the process' data buffer large enough */
1023
934
                 BUFFER_SIZE);
1024
935
      if(ret < 0){
1025
936
        /* Read error from this process; ignore the error */
1026
 
        proc = proc->next;
1027
937
        continue;
1028
938
      }
1029
939
      if(ret == 0){
1038
948
 
1039
949
 fallback:
1040
950
  
1041
 
  if(plugin_list == NULL or exitstatus != EXIT_SUCCESS){
 
951
  if(process_list == NULL or exitstatus != EXIT_SUCCESS){
1042
952
    /* Fallback if all plugins failed, none are found or an error
1043
953
       occured */
1044
954
    bool bret;
1045
955
    fprintf(stderr, "Going to fallback mode using getpass(3)\n");
1046
956
    char *passwordbuffer = getpass("Password: ");
1047
 
    size_t len = strlen(passwordbuffer);
1048
 
    /* Strip trailing newline */
1049
 
    if(len > 0 and passwordbuffer[len-1] == '\n'){
1050
 
      passwordbuffer[len-1] = '\0'; /* not strictly necessary */
1051
 
      len--;
1052
 
    }
1053
 
    bret = print_out_password(passwordbuffer, len);
 
957
    bret = print_out_password(passwordbuffer, strlen(passwordbuffer));
1054
958
    if(not bret){
1055
959
      perror("print_out_password");
1056
960
      exitstatus = EXIT_FAILURE;
1063
967
    perror("sigaction");
1064
968
    exitstatus = EXIT_FAILURE;
1065
969
  }
1066
 
  
 
970
 
1067
971
  if(custom_argv != NULL){
1068
972
    for(char **arg = custom_argv+1; *arg != NULL; arg++){
1069
973
      free(*arg);
1070
974
    }
1071
975
    free(custom_argv);
1072
976
  }
 
977
  free_plugin_list(plugin_list);
1073
978
  
1074
979
  if(dir != NULL){
1075
980
    closedir(dir);
1076
981
  }
1077
982
  
1078
 
  /* Kill the processes */
1079
 
  for(plugin *p = plugin_list; p != NULL; p = p->next){
1080
 
    if(p->pid != 0){
1081
 
      close(p->fd);
1082
 
      ret = kill(p->pid, SIGTERM);
1083
 
      if(ret == -1 and errno != ESRCH){
1084
 
        /* Set-uid proccesses might not get closed */
1085
 
        perror("kill");
1086
 
      }
 
983
  /* Free the process list and kill the processes */
 
984
  for(process *next; process_list != NULL; process_list = next){
 
985
    next = process_list->next;
 
986
    close(process_list->fd);
 
987
    ret = kill(process_list->pid, SIGTERM);
 
988
    if(ret == -1 and errno != ESRCH){
 
989
      /* set-uid proccesses migth not get closed */
 
990
      perror("kill");
1087
991
    }
 
992
    free(process_list->buffer);
 
993
    free(process_list);
1088
994
  }
1089
995
  
1090
996
  /* Wait for any remaining child processes to terminate */
1094
1000
  if(errno != ECHILD){
1095
1001
    perror("wait");
1096
1002
  }
1097
 
  
1098
 
  free_plugin_list();
1099
 
  
 
1003
 
1100
1004
  free(plugindir);
1101
1005
  free(argfile);
1102
1006