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
- browse files at revision 541
- compare with another revision
- download diff
- download tarball
- view history from revision 541
- Committer: Teddy Hogeborn
- Date: 2011-12-31 20:07:11 UTC
- mfrom: (535.1.9 wireless-network-hook)
- Revision ID: teddy@recompile.se-20111231200711-6dli3r8drftem57r
Merge new wireless network hook. Fix bridge network hook to use
hardware addresses instead of interface names. Implement and document
new "CONNECT" environment variable for network hooks.
hardware addresses instead of interface names. Implement and document
new "CONNECT" environment variable for network hooks.
- files added:
- DBUS-API
- debian/source
- network-hooks.d
- files modified:
- .bzrignore
added
removed
plugin-runner.c
1
/* -*- coding: utf-8 -*- */
1
/* -*- coding: utf-8; mode: c; mode: orgtbl -*- */
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-2011 Teddy Hogeborn
6
* Copyright © 2008-2011 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() */
26
asprintf(), O_CLOEXEC */
27
27
#include <stddef.h> /* size_t, NULL */
28
#include <stdlib.h> /* malloc(), exit(), EXIT_FAILURE,
29
EXIT_SUCCESS, realloc() */
28
#include <stdlib.h> /* malloc(), exit(), EXIT_SUCCESS,
29
realloc() */
30
30
#include <stdbool.h> /* bool, true, false */
31
#include <stdio.h> /* perror, fileno(), fprintf(),
31
#include <stdio.h> /* fileno(), fprintf(),
32
32
stderr, STDOUT_FILENO */
33
#include <sys/types.h> /* DIR, opendir(), stat(), struct
33
#include <sys/types.h> /* DIR, fdopendir(), stat(), struct
34
34
stat, waitpid(), WIFEXITED(),
35
35
WEXITSTATUS(), wait(), pid_t,
36
36
uid_t, gid_t, getuid(), getgid(),
38
38
#include <sys/select.h> /* fd_set, select(), FD_ZERO(),
39
39
FD_SET(), FD_ISSET(), FD_CLR */
40
40
#include <sys/wait.h> /* wait(), waitpid(), WIFEXITED(),
41
WEXITSTATUS() */
41
WEXITSTATUS(), WTERMSIG(),
42
WCOREDUMP() */
42
43
#include <sys/stat.h> /* struct stat, stat(), S_ISREG() */
43
44
#include <iso646.h> /* and, or, not */
44
#include <dirent.h> /* DIR, struct dirent, opendir(),
45
#include <dirent.h> /* DIR, struct dirent, fdopendir(),
45
46
readdir(), closedir(), dirfd() */
46
47
#include <unistd.h> /* struct stat, stat(), S_ISREG(),
47
48
fcntl(), setuid(), setgid(),
52
53
close() */
53
54
#include <fcntl.h> /* fcntl(), F_GETFD, F_SETFD,
54
55
FD_CLOEXEC */
55
#include <string.h> /* strsep, strlen(), asprintf() */
56
#include <string.h> /* strsep, strlen(), asprintf(),
57
strsignal(), strcmp(), strncmp() */
56
58
#include <errno.h> /* errno */
57
59
#include <argp.h> /* struct argp_option, struct
58
60
argp_state, struct argp,
62
64
#include <signal.h> /* struct sigaction, sigemptyset(),
63
65
sigaddset(), sigaction(),
64
66
sigprocmask(), SIG_BLOCK, SIGCHLD,
65
SIG_UNBLOCK, kill() */
67
SIG_UNBLOCK, kill(), sig_atomic_t
68
*/
66
69
#include <errno.h> /* errno, EBADF */
70
#include <inttypes.h> /* intmax_t, PRIdMAX, strtoimax() */
71
#include <sysexits.h> /* EX_OSERR, EX_USAGE, EX_IOERR,
72
EX_CONFIG, EX_UNAVAILABLE, EX_OK */
73
#include <errno.h> /* errno */
74
#include <error.h> /* error() */
67
75
68
76
#define BUFFER_SIZE 256
69
77
71
79
#define AFILE "/conf/conf.d/mandos/plugin-runner.conf"
72
80
73
81
const char *argp_program_version = "plugin-runner " VERSION;
74
const char *argp_program_bug_address = "<mandos@fukt.bsnet.se>";
82
const char *argp_program_bug_address = "<mandos@recompile.se>";
75
83
76
84
typedef struct plugin{
77
85
char *name; /* can be NULL or any plugin name */
80
88
char **environ;
81
89
int envc;
82
90
bool disabled;
83
91
84
92
/* Variables used for running processes*/
85
93
pid_t pid;
86
94
int fd;
88
96
size_t buffer_size;
89
97
size_t buffer_length;
90
98
bool eof;
91
volatile bool completed;
92
volatile int status;
99
volatile sig_atomic_t completed;
100
int status;
93
101
struct plugin *next;
94
102
} plugin;
95
103
98
106
/* Gets an existing plugin based on name,
99
107
or if none is found, creates a new one */
100
108
static plugin *getplugin(char *name){
101
/* Check for exiting plugin with that name */
102
for (plugin *p = plugin_list; p != NULL; p = p->next){
103
if ((p->name == name)
104
or (p->name and name and (strcmp(p->name, name) == 0))){
109
/* Check for existing plugin with that name */
110
for(plugin *p = plugin_list; p != NULL; p = p->next){
111
if((p->name == name)
112
or (p->name and name and (strcmp(p->name, name) == 0))){
105
113
return p;
106
114
}
107
115
}
108
116
/* Create a new plugin */
109
plugin *new_plugin = malloc(sizeof(plugin));
110
if (new_plugin == NULL){
117
plugin *new_plugin = NULL;
118
do {
119
new_plugin = malloc(sizeof(plugin));
120
} while(new_plugin == NULL and errno == EINTR);
121
if(new_plugin == NULL){
111
122
return NULL;
112
123
}
113
124
char *copy_name = NULL;
114
125
if(name != NULL){
115
copy_name = strdup(name);
126
do {
127
copy_name = strdup(name);
128
} while(copy_name == NULL and errno == EINTR);
116
129
if(copy_name == NULL){
130
int e = errno;
131
free(new_plugin);
132
errno = e;
117
133
return NULL;
118
134
}
119
135
}
120
136
121
*new_plugin = (plugin) { .name = copy_name,
122
.argc = 1,
123
.disabled = false,
124
.next = plugin_list };
137
*new_plugin = (plugin){ .name = copy_name,
138
.argc = 1,
139
.disabled = false,
140
.next = plugin_list };
125
141
126
new_plugin->argv = malloc(sizeof(char *) * 2);
127
if (new_plugin->argv == NULL){
142
do {
143
new_plugin->argv = malloc(sizeof(char *) * 2);
144
} while(new_plugin->argv == NULL and errno == EINTR);
145
if(new_plugin->argv == NULL){
146
int e = errno;
128
147
free(copy_name);
129
148
free(new_plugin);
149
errno = e;
130
150
return NULL;
131
151
}
132
152
new_plugin->argv[0] = copy_name;
133
153
new_plugin->argv[1] = NULL;
134
154
135
new_plugin->environ = malloc(sizeof(char *));
155
do {
156
new_plugin->environ = malloc(sizeof(char *));
157
} while(new_plugin->environ == NULL and errno == EINTR);
136
158
if(new_plugin->environ == NULL){
159
int e = errno;
137
160
free(copy_name);
138
161
free(new_plugin->argv);
139
162
free(new_plugin);
163
errno = e;
140
164
return NULL;
141
165
}
142
166
new_plugin->environ[0] = NULL;
147
171
}
148
172
149
173
/* Helper function for add_argument and add_environment */
174
__attribute__((nonnull))
150
175
static bool add_to_char_array(const char *new, char ***array,
151
176
int *len){
152
177
/* Resize the pointed-to array to hold one more pointer */
153
*array = realloc(*array, sizeof(char *)
154
* (size_t) ((*len) + 2));
178
do {
179
*array = realloc(*array, sizeof(char *)
180
* (size_t) ((*len) + 2));
181
} while(*array == NULL and errno == EINTR);
155
182
/* Malloc check */
156
183
if(*array == NULL){
157
184
return false;
158
185
}
159
186
/* Make a copy of the new string */
160
char *copy = strdup(new);
187
char *copy;
188
do {
189
copy = strdup(new);
190
} while(copy == NULL and errno == EINTR);
161
191
if(copy == NULL){
162
192
return false;
163
193
}
170
200
}
171
201
172
202
/* Add to a plugin's argument vector */
203
__attribute__((nonnull(2)))
173
204
static bool add_argument(plugin *p, const char *arg){
174
205
if(p == NULL){
175
206
return false;
178
209
}
179
210
180
211
/* Add to a plugin's environment */
212
__attribute__((nonnull(2)))
181
213
static bool add_environment(plugin *p, const char *def, bool replace){
182
214
if(p == NULL){
183
215
return false;
189
221
if(strncmp(*e, def, namelen + 1) == 0){
190
222
/* It already exists */
191
223
if(replace){
192
char *new = realloc(*e, strlen(def) + 1);
224
char *new;
225
do {
226
new = realloc(*e, strlen(def) + 1);
227
} while(new == NULL and errno == EINTR);
193
228
if(new == NULL){
194
229
return false;
195
230
}
205
240
/*
206
241
* Based on the example in the GNU LibC manual chapter 13.13 "File
207
242
* Descriptor Flags".
208
* *Note File Descriptor Flags:(libc)Descriptor Flags.
243
| [[info:libc:Descriptor%20Flags][File Descriptor Flags]] |
209
244
*/
210
245
static int set_cloexec_flag(int fd){
211
int ret = fcntl(fd, F_GETFD, 0);
246
int ret = (int)TEMP_FAILURE_RETRY(fcntl(fd, F_GETFD, 0));
212
247
/* If reading the flags failed, return error indication now. */
213
248
if(ret < 0){
214
249
return ret;
215
250
}
216
251
/* Store modified flag word in the descriptor. */
217
return fcntl(fd, F_SETFD, ret | FD_CLOEXEC);
252
return (int)TEMP_FAILURE_RETRY(fcntl(fd, F_SETFD,
253
ret | FD_CLOEXEC));
218
254
}
219
255
220
256
221
257
/* Mark processes as completed when they exit, and save their exit
222
258
status. */
223
259
static void handle_sigchld(__attribute__((unused)) int sig){
260
int old_errno = errno;
224
261
while(true){
225
262
plugin *proc = plugin_list;
226
263
int status;
230
267
break;
231
268
}
232
269
if(pid == -1){
233
if (errno != ECHILD){
234
perror("waitpid");
270
if(errno == ECHILD){
271
/* No child processes */
272
break;
235
273
}
236
/* No child processes */
237
break;
274
error(0, errno, "waitpid");
238
275
}
239
276
240
277
/* A child exited, find it in process_list */
246
283
continue;
247
284
}
248
285
proc->status = status;
249
proc->completed = true;
286
proc->completed = 1;
250
287
}
288
errno = old_errno;
251
289
}
252
290
253
291
/* Prints out a password to stdout */
292
__attribute__((nonnull))
254
293
static bool print_out_password(const char *buffer, size_t length){
255
294
ssize_t ret;
256
295
for(size_t written = 0; written < length; written += (size_t)ret){
264
303
}
265
304
266
305
/* Removes and free a plugin from the plugin list */
306
__attribute__((nonnull))
267
307
static void free_plugin(plugin *plugin_node){
268
308
269
309
for(char **arg = plugin_node->argv; *arg != NULL; arg++){
275
315
}
276
316
free(plugin_node->environ);
277
317
free(plugin_node->buffer);
278
318
279
319
/* Removes the plugin from the singly-linked list */
280
320
if(plugin_node == plugin_list){
281
321
/* First one - simple */
309
349
struct stat st;
310
350
fd_set rfds_all;
311
351
int ret, maxfd = 0;
352
ssize_t sret;
312
353
uid_t uid = 65534;
313
354
gid_t gid = 65534;
314
355
bool debug = false;
323
364
sigemptyset(&sigchld_action.sa_mask);
324
365
ret = sigaddset(&sigchld_action.sa_mask, SIGCHLD);
325
366
if(ret == -1){
326
perror("sigaddset");
327
exitstatus = EXIT_FAILURE;
367
error(0, errno, "sigaddset");
368
exitstatus = EX_OSERR;
328
369
goto fallback;
329
370
}
330
371
ret = sigaction(SIGCHLD, &sigchld_action, &old_sigchld_action);
331
372
if(ret == -1){
332
perror("sigaction");
333
exitstatus = EXIT_FAILURE;
373
error(0, errno, "sigaction");
374
exitstatus = EX_OSERR;
334
375
goto fallback;
335
376
}
336
377
368
409
.doc = "Group ID the plugins will run as", .group = 3 },
369
410
{ .name = "debug", .key = 132,
370
411
.doc = "Debug mode", .group = 4 },
412
/*
413
* These reproduce what we would get without ARGP_NO_HELP
414
*/
415
{ .name = "help", .key = '?',
416
.doc = "Give this help list", .group = -1 },
417
{ .name = "usage", .key = -3,
418
.doc = "Give a short usage message", .group = -1 },
419
{ .name = "version", .key = 'V',
420
.doc = "Print program version", .group = -1 },
371
421
{ .name = NULL }
372
422
};
373
423
374
error_t parse_opt (int key, char *arg, __attribute__((unused))
375
struct argp_state *state) {
376
switch (key) {
424
__attribute__((nonnull(3)))
425
error_t parse_opt(int key, char *arg, struct argp_state *state){
426
errno = 0;
427
switch(key){
428
char *tmp;
429
intmax_t tmp_id;
377
430
case 'g': /* --global-options */
378
if (arg != NULL){
379
char *p;
380
while((p = strsep(&arg, ",")) != NULL){
381
if(p[0] == '\0'){
382
continue;
383
}
384
if(not add_argument(getplugin(NULL), p)){
385
perror("add_argument");
386
return ARGP_ERR_UNKNOWN;
431
{
432
char *plugin_option;
433
while((plugin_option = strsep(&arg, ",")) != NULL){
434
if(not add_argument(getplugin(NULL), plugin_option)){
435
break;
387
436
}
388
437
}
389
438
}
390
439
break;
391
440
case 'G': /* --global-env */
392
if(arg == NULL){
393
break;
394
}
395
if(not add_environment(getplugin(NULL), arg, true)){
396
perror("add_environment");
397
}
441
add_environment(getplugin(NULL), arg, true);
398
442
break;
399
443
case 'o': /* --options-for */
400
if (arg != NULL){
401
char *p_name = strsep(&arg, ":");
402
if(p_name[0] == '\0' or arg == NULL){
403
break;
404
}
405
char *opt = strsep(&arg, ":");
406
if(opt[0] == '\0' or opt == NULL){
407
break;
408
}
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;
444
{
445
char *option_list = strchr(arg, ':');
446
if(option_list == NULL){
447
argp_error(state, "No colon in \"%s\"", arg);
448
errno = EINVAL;
449
break;
450
}
451
*option_list = '\0';
452
option_list++;
453
if(arg[0] == '\0'){
454
argp_error(state, "Empty plugin name");
455
errno = EINVAL;
456
break;
457
}
458
char *option;
459
while((option = strsep(&option_list, ",")) != NULL){
460
if(not add_argument(getplugin(arg), option)){
461
break;
417
462
}
418
463
}
419
464
}
420
465
break;
421
466
case 'E': /* --env-for */
422
if(arg == NULL){
423
break;
424
}
425
467
{
426
468
char *envdef = strchr(arg, ':');
427
469
if(envdef == NULL){
470
argp_error(state, "No colon in \"%s\"", arg);
471
errno = EINVAL;
428
472
break;
429
473
}
430
474
*envdef = '\0';
431
if(not add_environment(getplugin(arg), envdef+1, true)){
432
perror("add_environment");
475
envdef++;
476
if(arg[0] == '\0'){
477
argp_error(state, "Empty plugin name");
478
errno = EINVAL;
479
break;
433
480
}
481
add_environment(getplugin(arg), envdef, true);
434
482
}
435
483
break;
436
484
case 'd': /* --disable */
437
if (arg != NULL){
485
{
438
486
plugin *p = getplugin(arg);
439
if(p == NULL){
440
return ARGP_ERR_UNKNOWN;
487
if(p != NULL){
488
p->disabled = true;
441
489
}
442
p->disabled = true;
443
490
}
444
491
break;
445
492
case 'e': /* --enable */
446
if (arg != NULL){
493
{
447
494
plugin *p = getplugin(arg);
448
if(p == NULL){
449
return ARGP_ERR_UNKNOWN;
495
if(p != NULL){
496
p->disabled = false;
450
497
}
451
p->disabled = false;
452
498
}
453
499
break;
454
500
case 128: /* --plugin-dir */
455
501
free(plugindir);
456
502
plugindir = strdup(arg);
457
if(plugindir == NULL){
458
perror("strdup");
459
}
460
503
break;
461
504
case 129: /* --config-file */
462
505
/* This is already done by parse_opt_config_file() */
463
506
break;
464
507
case 130: /* --userid */
465
uid = (uid_t)strtol(arg, NULL, 10);
508
tmp_id = strtoimax(arg, &tmp, 10);
509
if(errno != 0 or tmp == arg or *tmp != '\0'
510
or tmp_id != (uid_t)tmp_id){
511
argp_error(state, "Bad user ID number: \"%s\", using %"
512
PRIdMAX, arg, (intmax_t)uid);
513
break;
514
}
515
uid = (uid_t)tmp_id;
466
516
break;
467
517
case 131: /* --groupid */
468
gid = (gid_t)strtol(arg, NULL, 10);
518
tmp_id = strtoimax(arg, &tmp, 10);
519
if(errno != 0 or tmp == arg or *tmp != '\0'
520
or tmp_id != (gid_t)tmp_id){
521
argp_error(state, "Bad group ID number: \"%s\", using %"
522
PRIdMAX, arg, (intmax_t)gid);
523
break;
524
}
525
gid = (gid_t)tmp_id;
469
526
break;
470
527
case 132: /* --debug */
471
528
debug = true;
472
529
break;
530
/*
531
* These reproduce what we would get without ARGP_NO_HELP
532
*/
533
case '?': /* --help */
534
state->flags &= ~(unsigned int)ARGP_NO_EXIT; /* force exit */
535
argp_state_help(state, state->out_stream, ARGP_HELP_STD_HELP);
536
case -3: /* --usage */
537
state->flags &= ~(unsigned int)ARGP_NO_EXIT; /* force exit */
538
argp_state_help(state, state->out_stream,
539
ARGP_HELP_USAGE | ARGP_HELP_EXIT_OK);
540
case 'V': /* --version */
541
fprintf(state->out_stream, "%s\n", argp_program_version);
542
exit(EXIT_SUCCESS);
543
break;
544
/*
545
* When adding more options before this line, remember to also add a
546
* "case" to the "parse_opt_config_file" function below.
547
*/
473
548
case ARGP_KEY_ARG:
474
549
/* Cryptsetup always passes an argument, which is an empty
475
550
string if "none" was specified in /etc/crypttab. So if
476
551
argument was empty, we ignore it silently. */
477
if(arg[0] != '\0'){
478
fprintf(stderr, "Ignoring unknown argument \"%s\"\n", arg);
552
if(arg[0] == '\0'){
553
break;
479
554
}
480
break;
481
case ARGP_KEY_END:
482
break;
483
555
default:
484
556
return ARGP_ERR_UNKNOWN;
485
557
}
486
return 0;
558
return errno; /* Set to 0 at start */
487
559
}
488
560
489
561
/* This option parser is the same as parse_opt() above, except it
490
562
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) {
563
error_t parse_opt_config_file(int key, char *arg,
564
__attribute__((unused))
565
struct argp_state *state){
566
errno = 0;
567
switch(key){
495
568
case 'g': /* --global-options */
496
569
case 'G': /* --global-env */
497
570
case 'o': /* --options-for */
503
576
case 129: /* --config-file */
504
577
free(argfile);
505
578
argfile = strdup(arg);
506
if(argfile == NULL){
507
perror("strdup");
508
}
509
break;
579
break;
510
580
case 130: /* --userid */
511
581
case 131: /* --groupid */
512
582
case 132: /* --debug */
583
case '?': /* --help */
584
case -3: /* --usage */
585
case 'V': /* --version */
513
586
case ARGP_KEY_ARG:
514
case ARGP_KEY_END:
515
587
break;
516
588
default:
517
589
return ARGP_ERR_UNKNOWN;
518
590
}
519
return 0;
591
return errno;
520
592
}
521
593
522
594
struct argp argp = { .options = options,
524
596
.args_doc = "",
525
597
.doc = "Mandos plugin runner -- Run plugins" };
526
598
527
/* Parse using the parse_opt_config_file in order to get the custom
599
/* Parse using parse_opt_config_file() in order to get the custom
528
600
config file location, if any. */
529
ret = argp_parse (&argp, argc, argv, ARGP_IN_ORDER, 0, NULL);
530
if (ret == ARGP_ERR_UNKNOWN){
531
fprintf(stderr, "Unknown error while parsing arguments\n");
532
exitstatus = EXIT_FAILURE;
601
ret = argp_parse(&argp, argc, argv,
602
ARGP_IN_ORDER | ARGP_NO_EXIT | ARGP_NO_HELP,
603
NULL, NULL);
604
switch(ret){
605
case 0:
606
break;
607
case ENOMEM:
608
default:
609
errno = ret;
610
error(0, errno, "argp_parse");
611
exitstatus = EX_OSERR;
612
goto fallback;
613
case EINVAL:
614
exitstatus = EX_USAGE;
533
615
goto fallback;
534
616
}
535
617
537
619
argp.parser = parse_opt;
538
620
539
621
/* Open the configfile if available */
540
if (argfile == NULL){
622
if(argfile == NULL){
541
623
conffp = fopen(AFILE, "r");
542
624
} else {
543
625
conffp = fopen(argfile, "r");
544
}
626
}
545
627
if(conffp != NULL){
546
628
char *org_line = NULL;
547
629
char *p, *arg, *new_arg, *line;
548
630
size_t size = 0;
549
ssize_t sret;
550
631
const char whitespace_delims[] = " \r\t\f\v\n";
551
632
const char comment_delim[] = "#";
552
633
553
634
custom_argc = 1;
554
635
custom_argv = malloc(sizeof(char*) * 2);
555
636
if(custom_argv == NULL){
556
perror("malloc");
557
exitstatus = EXIT_FAILURE;
637
error(0, errno, "malloc");
638
exitstatus = EX_OSERR;
558
639
goto fallback;
559
640
}
560
641
custom_argv[0] = argv[0];
561
642
custom_argv[1] = NULL;
562
643
563
644
/* for each line in the config file, strip whitespace and ignore
564
645
commented text */
565
646
while(true){
567
648
if(sret == -1){
568
649
break;
569
650
}
570
651
571
652
line = org_line;
572
653
arg = strsep(&line, comment_delim);
573
654
while((p = strsep(&arg, whitespace_delims)) != NULL){
576
657
}
577
658
new_arg = strdup(p);
578
659
if(new_arg == NULL){
579
perror("strdup");
580
exitstatus = EXIT_FAILURE;
660
error(0, errno, "strdup");
661
exitstatus = EX_OSERR;
581
662
free(org_line);
582
663
goto fallback;
583
664
}
586
667
custom_argv = realloc(custom_argv, sizeof(char *)
587
668
* ((unsigned int) custom_argc + 1));
588
669
if(custom_argv == NULL){
589
perror("realloc");
590
exitstatus = EXIT_FAILURE;
670
error(0, errno, "realloc");
671
exitstatus = EX_OSERR;
591
672
free(org_line);
592
673
goto fallback;
593
674
}
594
675
custom_argv[custom_argc-1] = new_arg;
595
custom_argv[custom_argc] = NULL;
676
custom_argv[custom_argc] = NULL;
596
677
}
597
678
}
679
do {
680
ret = fclose(conffp);
681
} while(ret == EOF and errno == EINTR);
682
if(ret == EOF){
683
error(0, errno, "fclose");
684
exitstatus = EX_IOERR;
685
goto fallback;
686
}
598
687
free(org_line);
599
688
} else {
600
689
/* Check for harmful errors and go to fallback. Other errors might
601
690
not affect opening plugins */
602
if (errno == EMFILE or errno == ENFILE or errno == ENOMEM){
603
perror("fopen");
604
exitstatus = EXIT_FAILURE;
691
if(errno == EMFILE or errno == ENFILE or errno == ENOMEM){
692
error(0, errno, "fopen");
693
exitstatus = EX_OSERR;
605
694
goto fallback;
606
695
}
607
696
}
608
/* If there was any arguments from configuration file,
609
pass them to parser as command arguments */
697
/* If there were any arguments from the configuration file, pass
698
them to parser as command line arguments */
610
699
if(custom_argv != NULL){
611
ret = argp_parse (&argp, custom_argc, custom_argv, ARGP_IN_ORDER,
612
0, NULL);
613
if (ret == ARGP_ERR_UNKNOWN){
614
fprintf(stderr, "Unknown error while parsing arguments\n");
615
exitstatus = EXIT_FAILURE;
700
ret = argp_parse(&argp, custom_argc, custom_argv,
701
ARGP_IN_ORDER | ARGP_NO_EXIT | ARGP_NO_HELP,
702
NULL, NULL);
703
switch(ret){
704
case 0:
705
break;
706
case ENOMEM:
707
default:
708
errno = ret;
709
error(0, errno, "argp_parse");
710
exitstatus = EX_OSERR;
711
goto fallback;
712
case EINVAL:
713
exitstatus = EX_CONFIG;
616
714
goto fallback;
617
715
}
618
716
}
619
717
620
718
/* Parse actual command line arguments, to let them override the
621
719
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;
720
ret = argp_parse(&argp, argc, argv,
721
ARGP_IN_ORDER | ARGP_NO_EXIT | ARGP_NO_HELP,
722
NULL, NULL);
723
switch(ret){
724
case 0:
725
break;
726
case ENOMEM:
727
default:
728
errno = ret;
729
error(0, errno, "argp_parse");
730
exitstatus = EX_OSERR;
731
goto fallback;
732
case EINVAL:
733
exitstatus = EX_USAGE;
626
734
goto fallback;
627
735
}
628
736
633
741
for(char **a = p->argv; *a != NULL; a++){
634
742
fprintf(stderr, "\tArg: %s\n", *a);
635
743
}
636
fprintf(stderr, "...and %u environment variables\n", p->envc);
744
fprintf(stderr, "...and %d environment variables\n", p->envc);
637
745
for(char **a = p->environ; *a != NULL; a++){
638
746
fprintf(stderr, "\t%s\n", *a);
639
747
}
640
748
}
641
749
}
642
750
643
/* Strip permissions down to nobody */
751
if(getuid() == 0){
752
/* Work around Debian bug #633582:
753
<http://bugs.debian.org/633582> */
754
int plugindir_fd = open(/* plugindir or */ PDIR, O_RDONLY);
755
if(plugindir_fd == -1){
756
error(0, errno, "open");
757
} else {
758
ret = (int)TEMP_FAILURE_RETRY(fstat(plugindir_fd, &st));
759
if(ret == -1){
760
error(0, errno, "fstat");
761
} else {
762
if(S_ISDIR(st.st_mode) and st.st_uid == 0 and st.st_gid == 0){
763
ret = fchown(plugindir_fd, uid, gid);
764
if(ret == -1){
765
error(0, errno, "fchown");
766
}
767
}
768
}
769
TEMP_FAILURE_RETRY(close(plugindir_fd));
770
}
771
}
772
773
/* Lower permissions */
774
setgid(gid);
775
if(ret == -1){
776
error(0, errno, "setgid");
777
}
644
778
ret = setuid(uid);
645
if (ret == -1){
646
perror("setuid");
647
}
648
setgid(gid);
649
if (ret == -1){
650
perror("setgid");
651
}
652
653
if (plugindir == NULL){
654
dir = opendir(PDIR);
655
} else {
656
dir = opendir(plugindir);
657
}
658
659
if(dir == NULL){
660
perror("Could not open plugin dir");
661
exitstatus = EXIT_FAILURE;
662
goto fallback;
663
}
664
665
/* Set the FD_CLOEXEC flag on the directory, if possible */
779
if(ret == -1){
780
error(0, errno, "setuid");
781
}
782
783
/* Open plugin directory with close_on_exec flag */
666
784
{
667
int dir_fd = dirfd(dir);
668
if(dir_fd >= 0){
669
ret = set_cloexec_flag(dir_fd);
670
if(ret < 0){
671
perror("set_cloexec_flag");
672
exitstatus = EXIT_FAILURE;
673
goto fallback;
674
}
785
int dir_fd = -1;
786
if(plugindir == NULL){
787
dir_fd = open(PDIR, O_RDONLY |
788
#ifdef O_CLOEXEC
789
O_CLOEXEC
790
#else /* not O_CLOEXEC */
791
0
792
#endif /* not O_CLOEXEC */
793
);
794
} else {
795
dir_fd = open(plugindir, O_RDONLY |
796
#ifdef O_CLOEXEC
797
O_CLOEXEC
798
#else /* not O_CLOEXEC */
799
0
800
#endif /* not O_CLOEXEC */
801
);
802
}
803
if(dir_fd == -1){
804
error(0, errno, "Could not open plugin dir");
805
exitstatus = EX_UNAVAILABLE;
806
goto fallback;
807
}
808
809
#ifndef O_CLOEXEC
810
/* Set the FD_CLOEXEC flag on the directory */
811
ret = set_cloexec_flag(dir_fd);
812
if(ret < 0){
813
error(0, errno, "set_cloexec_flag");
814
TEMP_FAILURE_RETRY(close(dir_fd));
815
exitstatus = EX_OSERR;
816
goto fallback;
817
}
818
#endif /* O_CLOEXEC */
819
820
dir = fdopendir(dir_fd);
821
if(dir == NULL){
822
error(0, errno, "Could not open plugin dir");
823
TEMP_FAILURE_RETRY(close(dir_fd));
824
exitstatus = EX_OSERR;
825
goto fallback;
675
826
}
676
827
}
677
828
679
830
680
831
/* Read and execute any executable in the plugin directory*/
681
832
while(true){
682
dirst = readdir(dir);
833
do {
834
dirst = readdir(dir);
835
} while(dirst == NULL and errno == EINTR);
683
836
684
837
/* All directory entries have been processed */
685
838
if(dirst == NULL){
686
if (errno == EBADF){
687
perror("readdir");
688
exitstatus = EXIT_FAILURE;
839
if(errno == EBADF){
840
error(0, errno, "readdir");
841
exitstatus = EX_IOERR;
689
842
goto fallback;
690
843
}
691
844
break;
721
874
for(const char **suf = bad_suffixes; *suf != NULL; suf++){
722
875
size_t suf_len = strlen(*suf);
723
876
if((d_name_len >= suf_len)
724
and (strcmp((dirst->d_name)+d_name_len-suf_len, *suf)
877
and (strcmp((dirst->d_name) + d_name_len-suf_len, *suf)
725
878
== 0)){
726
879
if(debug){
727
880
fprintf(stderr, "Ignoring plugin dir entry \"%s\""
736
889
continue;
737
890
}
738
891
}
739
892
740
893
char *filename;
741
894
if(plugindir == NULL){
742
ret = asprintf(&filename, PDIR "/%s", dirst->d_name);
895
ret = (int)TEMP_FAILURE_RETRY(asprintf(&filename, PDIR "/%s",
896
dirst->d_name));
743
897
} else {
744
ret = asprintf(&filename, "%s/%s", plugindir, dirst->d_name);
898
ret = (int)TEMP_FAILURE_RETRY(asprintf(&filename, "%s/%s",
899
plugindir,
900
dirst->d_name));
745
901
}
746
902
if(ret < 0){
747
perror("asprintf");
903
error(0, errno, "asprintf");
748
904
continue;
749
905
}
750
906
751
ret = stat(filename, &st);
752
if (ret == -1){
753
perror("stat");
907
ret = (int)TEMP_FAILURE_RETRY(stat(filename, &st));
908
if(ret == -1){
909
error(0, errno, "stat");
754
910
free(filename);
755
911
continue;
756
912
}
757
913
758
914
/* Ignore non-executable files */
759
if (not S_ISREG(st.st_mode) or (access(filename, X_OK) != 0)){
915
if(not S_ISREG(st.st_mode)
916
or (TEMP_FAILURE_RETRY(access(filename, X_OK)) != 0)){
760
917
if(debug){
761
918
fprintf(stderr, "Ignoring plugin dir entry \"%s\""
762
919
" with bad type or mode\n", filename);
767
924
768
925
plugin *p = getplugin(dirst->d_name);
769
926
if(p == NULL){
770
perror("getplugin");
927
error(0, errno, "getplugin");
771
928
free(filename);
772
929
continue;
773
930
}
785
942
if(g != NULL){
786
943
for(char **a = g->argv + 1; *a != NULL; a++){
787
944
if(not add_argument(p, *a)){
788
perror("add_argument");
945
error(0, errno, "add_argument");
789
946
}
790
947
}
791
948
/* Add global environment variables */
792
949
for(char **e = g->environ; *e != NULL; e++){
793
950
if(not add_environment(p, *e, false)){
794
perror("add_environment");
951
error(0, errno, "add_environment");
795
952
}
796
953
}
797
954
}
802
959
if(p->environ[0] != NULL){
803
960
for(char **e = environ; *e != NULL; e++){
804
961
if(not add_environment(p, *e, false)){
805
perror("add_environment");
962
error(0, errno, "add_environment");
806
963
}
807
964
}
808
965
}
809
966
810
967
int pipefd[2];
811
ret = pipe(pipefd);
812
if (ret == -1){
813
perror("pipe");
814
exitstatus = EXIT_FAILURE;
968
ret = (int)TEMP_FAILURE_RETRY(pipe(pipefd));
969
if(ret == -1){
970
error(0, errno, "pipe");
971
exitstatus = EX_OSERR;
815
972
goto fallback;
816
973
}
817
974
/* Ask OS to automatic close the pipe on exec */
818
975
ret = set_cloexec_flag(pipefd[0]);
819
976
if(ret < 0){
820
perror("set_cloexec_flag");
821
exitstatus = EXIT_FAILURE;
977
error(0, errno, "set_cloexec_flag");
978
exitstatus = EX_OSERR;
822
979
goto fallback;
823
980
}
824
981
ret = set_cloexec_flag(pipefd[1]);
825
982
if(ret < 0){
826
perror("set_cloexec_flag");
827
exitstatus = EXIT_FAILURE;
983
error(0, errno, "set_cloexec_flag");
984
exitstatus = EX_OSERR;
828
985
goto fallback;
829
986
}
830
987
/* Block SIGCHLD until process is safely in process list */
831
ret = sigprocmask (SIG_BLOCK, &sigchld_action.sa_mask, NULL);
988
ret = (int)TEMP_FAILURE_RETRY(sigprocmask(SIG_BLOCK,
989
&sigchld_action.sa_mask,
990
NULL));
832
991
if(ret < 0){
833
perror("sigprocmask");
834
exitstatus = EXIT_FAILURE;
992
error(0, errno, "sigprocmask");
993
exitstatus = EX_OSERR;
835
994
goto fallback;
836
995
}
837
996
/* Starting a new process to be watched */
838
pid_t pid = fork();
997
pid_t pid;
998
do {
999
pid = fork();
1000
} while(pid == -1 and errno == EINTR);
839
1001
if(pid == -1){
840
perror("fork");
841
exitstatus = EXIT_FAILURE;
1002
error(0, errno, "fork");
1003
exitstatus = EX_OSERR;
842
1004
goto fallback;
843
1005
}
844
1006
if(pid == 0){
845
1007
/* this is the child process */
846
1008
ret = sigaction(SIGCHLD, &old_sigchld_action, NULL);
847
1009
if(ret < 0){
848
perror("sigaction");
849
_exit(EXIT_FAILURE);
1010
error(0, errno, "sigaction");
1011
_exit(EX_OSERR);
850
1012
}
851
1013
ret = sigprocmask(SIG_UNBLOCK, &sigchld_action.sa_mask, NULL);
852
1014
if(ret < 0){
853
perror("sigprocmask");
854
_exit(EXIT_FAILURE);
1015
error(0, errno, "sigprocmask");
1016
_exit(EX_OSERR);
855
1017
}
856
1018
857
1019
ret = dup2(pipefd[1], STDOUT_FILENO); /* replace our stdout */
858
1020
if(ret == -1){
859
perror("dup2");
860
_exit(EXIT_FAILURE);
1021
error(0, errno, "dup2");
1022
_exit(EX_OSERR);
861
1023
}
862
1024
863
1025
if(dirfd(dir) < 0){
867
1029
}
868
1030
if(p->environ[0] == NULL){
869
1031
if(execv(filename, p->argv) < 0){
870
perror("execv");
871
_exit(EXIT_FAILURE);
1032
error(0, errno, "execv for %s", filename);
1033
_exit(EX_OSERR);
872
1034
}
873
1035
} else {
874
1036
if(execve(filename, p->argv, p->environ) < 0){
875
perror("execve");
876
_exit(EXIT_FAILURE);
1037
error(0, errno, "execve for %s", filename);
1038
_exit(EX_OSERR);
877
1039
}
878
1040
}
879
1041
/* no return */
880
1042
}
881
1043
/* Parent process */
882
close(pipefd[1]); /* Close unused write end of pipe */
1044
TEMP_FAILURE_RETRY(close(pipefd[1])); /* Close unused write end of
1045
pipe */
883
1046
free(filename);
884
1047
plugin *new_plugin = getplugin(dirst->d_name);
885
if (new_plugin == NULL){
886
perror("getplugin");
887
ret = sigprocmask (SIG_UNBLOCK, &sigchld_action.sa_mask, NULL);
1048
if(new_plugin == NULL){
1049
error(0, errno, "getplugin");
1050
ret = (int)(TEMP_FAILURE_RETRY
1051
(sigprocmask(SIG_UNBLOCK, &sigchld_action.sa_mask,
1052
NULL)));
888
1053
if(ret < 0){
889
perror("sigprocmask");
1054
error(0, errno, "sigprocmask");
890
1055
}
891
exitstatus = EXIT_FAILURE;
1056
exitstatus = EX_OSERR;
892
1057
goto fallback;
893
1058
}
894
1059
897
1062
898
1063
/* Unblock SIGCHLD so signal handler can be run if this process
899
1064
has already completed */
900
ret = sigprocmask (SIG_UNBLOCK, &sigchld_action.sa_mask, NULL);
1065
ret = (int)TEMP_FAILURE_RETRY(sigprocmask(SIG_UNBLOCK,
1066
&sigchld_action.sa_mask,
1067
NULL));
901
1068
if(ret < 0){
902
perror("sigprocmask");
903
exitstatus = EXIT_FAILURE;
1069
error(0, errno, "sigprocmask");
1070
exitstatus = EX_OSERR;
904
1071
goto fallback;
905
1072
}
906
1073
907
FD_SET(new_plugin->fd, &rfds_all);
1074
FD_SET(new_plugin->fd, &rfds_all); /* Spurious warning from
1075
-Wconversion */
908
1076
909
if (maxfd < new_plugin->fd){
1077
if(maxfd < new_plugin->fd){
910
1078
maxfd = new_plugin->fd;
911
1079
}
912
1080
}
913
1081
914
closedir(dir);
1082
TEMP_FAILURE_RETRY(closedir(dir));
915
1083
dir = NULL;
1084
free_plugin(getplugin(NULL));
916
1085
917
1086
for(plugin *p = plugin_list; p != NULL; p = p->next){
918
1087
if(p->pid != 0){
929
1098
while(plugin_list){
930
1099
fd_set rfds = rfds_all;
931
1100
int select_ret = select(maxfd+1, &rfds, NULL, NULL, NULL);
932
if (select_ret == -1){
933
perror("select");
934
exitstatus = EXIT_FAILURE;
1101
if(select_ret == -1 and errno != EINTR){
1102
error(0, errno, "select");
1103
exitstatus = EX_OSERR;
935
1104
goto fallback;
936
1105
}
937
1106
/* OK, now either a process completed, or something can be read
938
1107
from one of them */
939
1108
for(plugin *proc = plugin_list; proc != NULL;){
940
1109
/* Is this process completely done? */
941
if(proc->eof and proc->completed){
1110
if(proc->completed and proc->eof){
942
1111
/* Only accept the plugin output if it exited cleanly */
943
1112
if(not WIFEXITED(proc->status)
944
1113
or WEXITSTATUS(proc->status) != 0){
945
1114
/* Bad exit by plugin */
946
1115
947
1116
if(debug){
948
1117
if(WIFEXITED(proc->status)){
949
fprintf(stderr, "Plugin %u exited with status %d\n",
950
(unsigned int) (proc->pid),
1118
fprintf(stderr, "Plugin %s [%" PRIdMAX "] exited with"
1119
" status %d\n", proc->name,
1120
(intmax_t) (proc->pid),
951
1121
WEXITSTATUS(proc->status));
952
} else if(WIFSIGNALED(proc->status)) {
953
fprintf(stderr, "Plugin %u killed by signal %d\n",
954
(unsigned int) (proc->pid),
955
WTERMSIG(proc->status));
1122
} else if(WIFSIGNALED(proc->status)){
1123
fprintf(stderr, "Plugin %s [%" PRIdMAX "] killed by"
1124
" signal %d: %s\n", proc->name,
1125
(intmax_t) (proc->pid),
1126
WTERMSIG(proc->status),
1127
strsignal(WTERMSIG(proc->status)));
956
1128
} else if(WCOREDUMP(proc->status)){
957
fprintf(stderr, "Plugin %d dumped core\n",
958
(unsigned int) (proc->pid));
1129
fprintf(stderr, "Plugin %s [%" PRIdMAX "] dumped"
1130
" core\n", proc->name, (intmax_t) (proc->pid));
959
1131
}
960
1132
}
961
1133
962
1134
/* Remove the plugin */
963
FD_CLR(proc->fd, &rfds_all);
964
1135
FD_CLR(proc->fd, &rfds_all); /* Spurious warning from
1136
-Wconversion */
1137
965
1138
/* Block signal while modifying process_list */
966
ret = sigprocmask(SIG_BLOCK, &sigchld_action.sa_mask, NULL);
1139
ret = (int)TEMP_FAILURE_RETRY(sigprocmask
1140
(SIG_BLOCK,
1141
&sigchld_action.sa_mask,
1142
NULL));
967
1143
if(ret < 0){
968
perror("sigprocmask");
969
exitstatus = EXIT_FAILURE;
1144
error(0, errno, "sigprocmask");
1145
exitstatus = EX_OSERR;
970
1146
goto fallback;
971
1147
}
972
1148
975
1151
proc = next_plugin;
976
1152
977
1153
/* We are done modifying process list, so unblock signal */
978
ret = sigprocmask (SIG_UNBLOCK, &sigchld_action.sa_mask,
979
NULL);
1154
ret = (int)(TEMP_FAILURE_RETRY
1155
(sigprocmask(SIG_UNBLOCK,
1156
&sigchld_action.sa_mask, NULL)));
980
1157
if(ret < 0){
981
perror("sigprocmask");
982
exitstatus = EXIT_FAILURE;
1158
error(0, errno, "sigprocmask");
1159
exitstatus = EX_OSERR;
983
1160
goto fallback;
984
1161
}
985
1162
995
1172
bool bret = print_out_password(proc->buffer,
996
1173
proc->buffer_length);
997
1174
if(not bret){
998
perror("print_out_password");
999
exitstatus = EXIT_FAILURE;
1175
error(0, errno, "print_out_password");
1176
exitstatus = EX_IOERR;
1000
1177
}
1001
1178
goto fallback;
1002
1179
}
1003
1180
1004
1181
/* This process has not completed. Does it have any output? */
1005
if(proc->eof or not FD_ISSET(proc->fd, &rfds)){
1182
if(proc->eof or not FD_ISSET(proc->fd, &rfds)){ /* Spurious
1183
warning from
1184
-Wconversion */
1006
1185
/* This process had nothing to say at this time */
1007
1186
proc = proc->next;
1008
1187
continue;
1011
1190
if(proc->buffer_length + BUFFER_SIZE > proc->buffer_size){
1012
1191
proc->buffer = realloc(proc->buffer, proc->buffer_size
1013
1192
+ (size_t) BUFFER_SIZE);
1014
if (proc->buffer == NULL){
1015
perror("malloc");
1016
exitstatus = EXIT_FAILURE;
1193
if(proc->buffer == NULL){
1194
error(0, errno, "malloc");
1195
exitstatus = EX_OSERR;
1017
1196
goto fallback;
1018
1197
}
1019
1198
proc->buffer_size += BUFFER_SIZE;
1020
1199
}
1021
1200
/* Read from the process */
1022
ret = read(proc->fd, proc->buffer + proc->buffer_length,
1023
BUFFER_SIZE);
1024
if(ret < 0){
1201
sret = TEMP_FAILURE_RETRY(read(proc->fd,
1202
proc->buffer
1203
+ proc->buffer_length,
1204
BUFFER_SIZE));
1205
if(sret < 0){
1025
1206
/* Read error from this process; ignore the error */
1026
1207
proc = proc->next;
1027
1208
continue;
1028
1209
}
1029
if(ret == 0){
1210
if(sret == 0){
1030
1211
/* got EOF */
1031
1212
proc->eof = true;
1032
1213
} else {
1033
proc->buffer_length += (size_t) ret;
1214
proc->buffer_length += (size_t) sret;
1034
1215
}
1035
1216
}
1036
1217
}
1037
1038
1218
1219
1039
1220
fallback:
1040
1221
1041
if(plugin_list == NULL or exitstatus != EXIT_SUCCESS){
1222
if(plugin_list == NULL or (exitstatus != EXIT_SUCCESS
1223
and exitstatus != EX_OK)){
1042
1224
/* Fallback if all plugins failed, none are found or an error
1043
1225
occured */
1044
1226
bool bret;
1052
1234
}
1053
1235
bret = print_out_password(passwordbuffer, len);
1054
1236
if(not bret){
1055
perror("print_out_password");
1056
exitstatus = EXIT_FAILURE;
1237
error(0, errno, "print_out_password");
1238
exitstatus = EX_IOERR;
1057
1239
}
1058
1240
}
1059
1241
1060
1242
/* Restore old signal handler */
1061
1243
ret = sigaction(SIGCHLD, &old_sigchld_action, NULL);
1062
1244
if(ret == -1){
1063
perror("sigaction");
1064
exitstatus = EXIT_FAILURE;
1245
error(0, errno, "sigaction");
1246
exitstatus = EX_OSERR;
1065
1247
}
1066
1248
1067
1249
if(custom_argv != NULL){
1082
1264
ret = kill(p->pid, SIGTERM);
1083
1265
if(ret == -1 and errno != ESRCH){
1084
1266
/* Set-uid proccesses might not get closed */
1085
perror("kill");
1267
error(0, errno, "kill");
1086
1268
}
1087
1269
}
1088
1270
}
1089
1271
1090
1272
/* Wait for any remaining child processes to terminate */
1091
do{
1273
do {
1092
1274
ret = wait(NULL);
1093
1275
} while(ret >= 0);
1094
1276
if(errno != ECHILD){
1095
perror("wait");
1277
error(0, errno, "wait");
1096
1278
}
1097
1279
1098
1280
free_plugin_list();
Loggerhead is a web-based interface for Breezy
Version: 2.0.2.dev0