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