To get this branch, use:
bzr branch
http://bzr.recompile.se/loggerhead/mandos/release
« back to all changes in this revision
Viewing changes to plugbasedclient.c
- browse files at revision 39
- compare with another revision
- download diff
- download tarball
- view history from revision 39
- Committer: Teddy Hogeborn
- Date: 2008-08-03 03:33:56 UTC
- Revision ID: teddy@fukt.bsnet.se-20080803033356-6aemgj0g0hoz91ow
* plugins.d/mandosclient.c (pgp_packet_decrypt): Renamed variables.
On debug, show
decrypted plaintext
in hexadecimal. Free
the GPGME data
buffers even on
errors.
On debug, show
decrypted plaintext
in hexadecimal. Free
the GPGME data
buffers even on
errors.
- files added:
- ca.pem
- files removed:
- .bzr-builddeb
- debian
- debian/po
- files renamed:
- plugin-runner.c => plugbasedclient.c
- plugins.d/mandos-client.c => plugins.d/mandosclient.c
- plugins.d/password-prompt.c => plugins.d/passprompt.c
- mandos.conf => server.conf
- mandos => server.py
- files modified:
- Makefile
added
removed
plugbasedclient.c
1
/* -*- coding: utf-8; mode: c; mode: orgtbl -*- */
1
/* -*- coding: utf-8 -*- */
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
22
21
* Contact the authors at <mandos@fukt.bsnet.se>.
23
22
*/
24
23
25
#define _GNU_SOURCE /* TEMP_FAILURE_RETRY(), getline(),
26
asprintf() */
27
#include <stddef.h> /* size_t, NULL */
28
#include <stdlib.h> /* malloc(), exit(), EXIT_FAILURE,
29
EXIT_SUCCESS, realloc() */
30
#include <stdbool.h> /* bool, true, false */
31
#include <stdio.h> /* perror, fileno(), fprintf(),
24
#define _GNU_SOURCE /* TEMP_FAILURE_RETRY() */
25
26
#include <stdio.h> /* popen(), fileno(), fprintf(),
32
27
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() */
38
#include <sys/select.h> /* fd_set, select(), FD_ZERO(),
39
FD_SET(), FD_ISSET(), FD_CLR */
40
#include <sys/wait.h> /* wait(), waitpid(), WIFEXITED(),
41
WEXITSTATUS(), WTERMSIG(),
42
WCOREDUMP() */
43
#include <sys/stat.h> /* struct stat, stat(), S_ISREG() */
44
28
#include <iso646.h> /* and, or, not */
29
#include <sys/types.h> /* DIR, opendir(), stat(),
30
struct stat, waitpid(),
31
WIFEXITED(), WEXITSTATUS(),
32
wait() */
33
#include <sys/wait.h> /* wait() */
45
34
#include <dirent.h> /* DIR, struct dirent, opendir(),
46
readdir(), closedir(), dirfd() */
35
readdir(), closedir() */
36
#include <sys/stat.h> /* struct stat, stat(), S_ISREG() */
47
37
#include <unistd.h> /* struct stat, stat(), S_ISREG(),
48
fcntl(), setuid(), setgid(),
49
F_GETFD, F_SETFD, FD_CLOEXEC,
50
access(), pipe(), fork(), close()
51
dup2(), STDOUT_FILENO, _exit(),
52
execv(), write(), read(),
53
close() */
54
#include <fcntl.h> /* fcntl(), F_GETFD, F_SETFD,
55
FD_CLOEXEC */
56
#include <string.h> /* strsep, strlen(), asprintf(),
57
strsignal() */
38
fcntl() */
39
#include <fcntl.h> /* fcntl() */
40
#include <stddef.h> /* NULL */
41
#include <stdlib.h> /* EXIT_FAILURE */
42
#include <sys/select.h> /* fd_set, select(), FD_ZERO(),
43
FD_SET(), FD_ISSET() */
44
#include <string.h> /* strlen(), strcpy(), strcat() */
45
#include <stdbool.h> /* true */
46
#include <sys/wait.h> /* waitpid(), WIFEXITED(),
47
WEXITSTATUS() */
58
48
#include <errno.h> /* errno */
59
#include <argp.h> /* struct argp_option, struct
60
argp_state, struct argp,
61
argp_parse(), ARGP_ERR_UNKNOWN,
62
ARGP_KEY_END, ARGP_KEY_ARG,
63
error_t */
64
#include <signal.h> /* struct sigaction, sigemptyset(),
65
sigaddset(), sigaction(),
66
sigprocmask(), SIG_BLOCK, SIGCHLD,
67
SIG_UNBLOCK, kill(), sig_atomic_t
68
*/
69
#include <errno.h> /* errno, EBADF */
70
#include <inttypes.h> /* intmax_t, PRIdMAX, strtoimax() */
49
#include <argp.h> /* struct argp_option,
50
struct argp_state, struct argp,
51
argp_parse() */
71
52
72
53
#define BUFFER_SIZE 256
73
54
74
#define PDIR "/lib/mandos/plugins.d"
75
#define AFILE "/conf/conf.d/mandos/plugin-runner.conf"
76
77
const char *argp_program_version = "plugin-runner " VERSION;
78
const char *argp_program_bug_address = "<mandos@fukt.bsnet.se>";
79
80
typedef struct plugin{
81
char *name; /* can be NULL or any plugin name */
82
char **argv;
83
int argc;
84
char **environ;
85
int envc;
86
bool disabled;
87
88
/* Variables used for running processes*/
55
struct process;
56
57
typedef struct process{
89
58
pid_t pid;
90
59
int fd;
91
60
char *buffer;
92
61
size_t buffer_size;
93
62
size_t buffer_length;
94
63
bool eof;
95
volatile sig_atomic_t completed;
64
bool completed;
96
65
int status;
66
struct process *next;
67
} process;
68
69
typedef struct plugin{
70
char *name; /* can be NULL or any plugin name */
71
char **argv;
72
int argc;
73
bool disabled;
97
74
struct plugin *next;
98
75
} plugin;
99
76
100
static plugin *plugin_list = NULL;
101
102
/* Gets an existing plugin based on name,
103
or if none is found, creates a new one */
104
static plugin *getplugin(char *name){
105
/* Check for exiting plugin with that name */
106
for(plugin *p = plugin_list; p != NULL; p = p->next){
107
if((p->name == name)
108
or (p->name and name and (strcmp(p->name, name) == 0))){
77
static plugin *getplugin(char *name, plugin **plugin_list){
78
for (plugin *p = *plugin_list; p != NULL; p = p->next){
79
if ((p->name == name)
80
or (p->name and name and (strcmp(p->name, name) == 0))){
109
81
return p;
110
82
}
111
83
}
112
84
/* Create a new plugin */
113
plugin *new_plugin = NULL;
114
do {
115
new_plugin = malloc(sizeof(plugin));
116
} while(new_plugin == NULL and errno == EINTR);
117
if(new_plugin == NULL){
118
return NULL;
119
}
120
char *copy_name = NULL;
121
if(name != NULL){
122
do {
123
copy_name = strdup(name);
124
} while(copy_name == NULL and errno == EINTR);
125
if(copy_name == NULL){
126
free(new_plugin);
127
return NULL;
128
}
129
}
130
131
*new_plugin = (plugin){ .name = copy_name,
132
.argc = 1,
133
.disabled = false,
134
.next = plugin_list };
135
136
do {
137
new_plugin->argv = malloc(sizeof(char *) * 2);
138
} while(new_plugin->argv == NULL and errno == EINTR);
139
if(new_plugin->argv == NULL){
140
free(copy_name);
141
free(new_plugin);
142
return NULL;
143
}
144
new_plugin->argv[0] = copy_name;
85
plugin *new_plugin = malloc(sizeof(plugin));
86
if (new_plugin == NULL){
87
perror("malloc");
88
exit(EXIT_FAILURE);
89
}
90
new_plugin->name = name;
91
new_plugin->argv = malloc(sizeof(char *) * 2);
92
if (new_plugin->argv == NULL){
93
perror("malloc");
94
exit(EXIT_FAILURE);
95
}
96
new_plugin->argv[0] = name;
145
97
new_plugin->argv[1] = NULL;
146
147
do {
148
new_plugin->environ = malloc(sizeof(char *));
149
} while(new_plugin->environ == NULL and errno == EINTR);
150
if(new_plugin->environ == NULL){
151
free(copy_name);
152
free(new_plugin->argv);
153
free(new_plugin);
154
return NULL;
155
}
156
new_plugin->environ[0] = NULL;
157
98
new_plugin->argc = 1;
99
new_plugin->disabled = false;
100
new_plugin->next = *plugin_list;
158
101
/* Append the new plugin to the list */
159
plugin_list = new_plugin;
102
*plugin_list = new_plugin;
160
103
return new_plugin;
161
104
}
162
105
163
/* Helper function for add_argument and add_environment */
164
static bool add_to_char_array(const char *new, char ***array,
165
int *len){
166
/* Resize the pointed-to array to hold one more pointer */
167
do {
168
*array = realloc(*array, sizeof(char *)
169
* (size_t) ((*len) + 2));
170
} while(*array == NULL and errno == EINTR);
171
/* Malloc check */
172
if(*array == NULL){
173
return false;
174
}
175
/* Make a copy of the new string */
176
char *copy;
177
do {
178
copy = strdup(new);
179
} while(copy == NULL and errno == EINTR);
180
if(copy == NULL){
181
return false;
182
}
183
/* Insert the copy */
184
(*array)[*len] = copy;
185
(*len)++;
186
/* Add a new terminating NULL pointer to the last element */
187
(*array)[*len] = NULL;
188
return true;
189
}
190
191
/* Add to a plugin's argument vector */
192
static bool add_argument(plugin *p, const char *arg){
193
if(p == NULL){
194
return false;
195
}
196
return add_to_char_array(arg, &(p->argv), &(p->argc));
197
}
198
199
/* Add to a plugin's environment */
200
static bool add_environment(plugin *p, const char *def, bool replace){
201
if(p == NULL){
202
return false;
203
}
204
/* namelen = length of name of environment variable */
205
size_t namelen = (size_t)(strchrnul(def, '=') - def);
206
/* Search for this environment variable */
207
for(char **e = p->environ; *e != NULL; e++){
208
if(strncmp(*e, def, namelen + 1) == 0){
209
/* It already exists */
210
if(replace){
211
char *new;
212
do {
213
new = realloc(*e, strlen(def) + 1);
214
} while(new == NULL and errno == EINTR);
215
if(new == NULL){
216
return false;
217
}
218
*e = new;
219
strcpy(*e, def);
220
}
221
return true;
222
}
223
}
224
return add_to_char_array(def, &(p->environ), &(p->envc));
106
static void addargument(plugin *p, char *arg){
107
p->argv[p->argc] = arg;
108
p->argv = realloc(p->argv, sizeof(char *) * (size_t)(p->argc + 2));
109
if (p->argv == NULL){
110
perror("malloc");
111
exit(EXIT_FAILURE);
112
}
113
p->argc++;
114
p->argv[p->argc] = NULL;
225
115
}
226
116
227
117
/*
228
118
* Based on the example in the GNU LibC manual chapter 13.13 "File
229
119
* Descriptor Flags".
230
| [[info:libc:Descriptor%20Flags][File Descriptor Flags]] |
120
* *Note File Descriptor Flags:(libc)Descriptor Flags.
231
121
*/
232
static int set_cloexec_flag(int fd){
233
int ret = (int)TEMP_FAILURE_RETRY(fcntl(fd, F_GETFD, 0));
122
static int set_cloexec_flag(int fd)
123
{
124
int ret = fcntl(fd, F_GETFD, 0);
234
125
/* If reading the flags failed, return error indication now. */
235
126
if(ret < 0){
236
127
return ret;
237
128
}
238
129
/* Store modified flag word in the descriptor. */
239
return (int)TEMP_FAILURE_RETRY(fcntl(fd, F_SETFD,
240
ret | FD_CLOEXEC));
130
return fcntl(fd, F_SETFD, ret | FD_CLOEXEC);
241
131
}
242
132
243
244
/* Mark processes as completed when they exit, and save their exit
133
const char *argp_program_version = "plugbasedclient 0.9";
134
const char *argp_program_bug_address = "<mandos@fukt.bsnet.se>";
135
136
process *process_list = NULL;
137
138
/* Mark a process as completed when it exits, and save its exit
245
139
status. */
246
static void handle_sigchld(__attribute__((unused)) int sig){
247
int old_errno = errno;
248
while(true){
249
plugin *proc = plugin_list;
250
int status;
251
pid_t pid = waitpid(-1, &status, WNOHANG);
252
if(pid == 0){
253
/* Only still running child processes */
254
break;
255
}
256
if(pid == -1){
257
if(errno == ECHILD){
258
/* No child processes */
259
break;
260
}
261
perror("waitpid");
262
}
263
264
/* A child exited, find it in process_list */
265
while(proc != NULL and proc->pid != pid){
266
proc = proc->next;
267
}
268
if(proc == NULL){
269
/* Process not found in process list */
270
continue;
271
}
272
proc->status = status;
273
proc->completed = 1;
274
}
275
errno = old_errno;
276
}
277
278
/* Prints out a password to stdout */
279
static bool print_out_password(const char *buffer, size_t length){
280
ssize_t ret;
281
for(size_t written = 0; written < length; written += (size_t)ret){
282
ret = TEMP_FAILURE_RETRY(write(STDOUT_FILENO, buffer + written,
283
length - written));
284
if(ret < 0){
285
return false;
286
}
287
}
288
return true;
289
}
290
291
/* Removes and free a plugin from the plugin list */
292
static void free_plugin(plugin *plugin_node){
293
294
for(char **arg = plugin_node->argv; *arg != NULL; arg++){
295
free(*arg);
296
}
297
free(plugin_node->argv);
298
for(char **env = plugin_node->environ; *env != NULL; env++){
299
free(*env);
300
}
301
free(plugin_node->environ);
302
free(plugin_node->buffer);
303
304
/* Removes the plugin from the singly-linked list */
305
if(plugin_node == plugin_list){
306
/* First one - simple */
307
plugin_list = plugin_list->next;
308
} else {
309
/* Second one or later */
310
for(plugin *p = plugin_list; p != NULL; p = p->next){
311
if(p->next == plugin_node){
312
p->next = plugin_node->next;
313
break;
314
}
315
}
316
}
317
318
free(plugin_node);
319
}
320
321
static void free_plugin_list(void){
322
while(plugin_list != NULL){
323
free_plugin(plugin_list);
324
}
140
void handle_sigchld(__attribute__((unused)) int sig){
141
process *proc = process_list;
142
int status;
143
pid_t pid = wait(&status);
144
while(proc != NULL and proc->pid != pid){
145
proc = proc->next;
146
}
147
if(proc == NULL){
148
/* Process not found in process list */
149
return;
150
}
151
proc->status = status;
152
proc->completed = true;
325
153
}
326
154
327
155
int main(int argc, char *argv[]){
328
char *plugindir = NULL;
329
char *argfile = NULL;
330
FILE *conffp;
156
const char *plugindir = "/conf/conf.d/mandos/plugins.d";
331
157
size_t d_name_len;
332
158
DIR *dir = NULL;
333
159
struct dirent *dirst;
334
160
struct stat st;
335
161
fd_set rfds_all;
336
162
int ret, maxfd = 0;
337
ssize_t sret;
338
163
uid_t uid = 65534;
339
164
gid_t gid = 65534;
340
165
bool debug = false;
342
167
struct sigaction old_sigchld_action;
343
168
struct sigaction sigchld_action = { .sa_handler = handle_sigchld,
344
169
.sa_flags = SA_NOCLDSTOP };
345
char **custom_argv = NULL;
346
int custom_argc = 0;
170
char *plus_options = NULL;
171
char **plus_argv = NULL;
347
172
348
173
/* Establish a signal handler */
349
174
sigemptyset(&sigchld_action.sa_mask);
350
175
ret = sigaddset(&sigchld_action.sa_mask, SIGCHLD);
351
if(ret == -1){
176
if(ret < 0){
352
177
perror("sigaddset");
353
exitstatus = EXIT_FAILURE;
354
goto fallback;
178
exit(EXIT_FAILURE);
355
179
}
356
180
ret = sigaction(SIGCHLD, &sigchld_action, &old_sigchld_action);
357
if(ret == -1){
181
if(ret < 0){
358
182
perror("sigaction");
359
exitstatus = EXIT_FAILURE;
360
goto fallback;
183
exit(EXIT_FAILURE);
361
184
}
362
185
363
186
/* The options we understand. */
365
188
{ .name = "global-options", .key = 'g',
366
189
.arg = "OPTION[,OPTION[,...]]",
367
190
.doc = "Options passed to all plugins" },
368
{ .name = "global-env", .key = 'G',
369
.arg = "VAR=value",
370
.doc = "Environment variable passed to all plugins" },
371
191
{ .name = "options-for", .key = 'o',
372
192
.arg = "PLUGIN:OPTION[,OPTION[,...]]",
373
193
.doc = "Options passed only to specified plugin" },
374
{ .name = "env-for", .key = 'E',
375
.arg = "PLUGIN:ENV=value",
376
.doc = "Environment variable passed to specified plugin" },
377
194
{ .name = "disable", .key = 'd',
378
195
.arg = "PLUGIN",
379
196
.doc = "Disable a specific plugin", .group = 1 },
380
{ .name = "enable", .key = 'e',
381
.arg = "PLUGIN",
382
.doc = "Enable a specific plugin", .group = 1 },
383
197
{ .name = "plugin-dir", .key = 128,
384
198
.arg = "DIRECTORY",
385
199
.doc = "Specify a different plugin directory", .group = 2 },
386
{ .name = "config-file", .key = 129,
387
.arg = "FILE",
388
.doc = "Specify a different configuration file", .group = 2 },
389
{ .name = "userid", .key = 130,
390
.arg = "ID", .flags = 0,
391
.doc = "User ID the plugins will run as", .group = 3 },
392
{ .name = "groupid", .key = 131,
393
.arg = "ID", .flags = 0,
394
.doc = "Group ID the plugins will run as", .group = 3 },
395
{ .name = "debug", .key = 132,
396
.doc = "Debug mode", .group = 4 },
200
{ .name = "userid", .key = 129,
201
.arg = "ID", .flags = 0,
202
.doc = "User ID the plugins will run as", .group = 2 },
203
{ .name = "groupid", .key = 130,
204
.arg = "ID", .flags = 0,
205
.doc = "Group ID the plugins will run as", .group = 2 },
206
{ .name = "debug", .key = 131,
207
.doc = "Debug mode", .group = 3 },
397
208
{ .name = NULL }
398
209
};
399
210
400
error_t parse_opt(int key, char *arg, __attribute__((unused))
401
struct argp_state *state){
402
switch(key){
403
char *tmp;
404
intmax_t tmpmax;
405
case 'g': /* --global-options */
406
if(arg != NULL){
407
char *plugin_option;
408
while((plugin_option = strsep(&arg, ",")) != NULL){
409
if(plugin_option[0] == '\0'){
410
continue;
411
}
412
if(not add_argument(getplugin(NULL), plugin_option)){
413
perror("add_argument");
414
return ARGP_ERR_UNKNOWN;
415
}
416
}
417
}
418
break;
419
case 'G': /* --global-env */
420
if(arg == NULL){
421
break;
422
}
423
if(not add_environment(getplugin(NULL), arg, true)){
424
perror("add_environment");
425
}
426
break;
427
case 'o': /* --options-for */
428
if(arg != NULL){
429
char *plugin_name = strsep(&arg, ":");
430
if(plugin_name[0] == '\0'){
431
break;
432
}
433
char *plugin_option;
434
while((plugin_option = strsep(&arg, ",")) != NULL){
435
if(not add_argument(getplugin(plugin_name), plugin_option)){
436
perror("add_argument");
437
return ARGP_ERR_UNKNOWN;
438
}
439
}
440
}
441
break;
442
case 'E': /* --env-for */
443
if(arg == NULL){
444
break;
445
}
446
{
447
char *envdef = strchr(arg, ':');
448
if(envdef == NULL){
449
break;
450
}
451
*envdef = '\0';
452
if(not add_environment(getplugin(arg), envdef+1, true)){
453
perror("add_environment");
454
}
455
}
456
break;
457
case 'd': /* --disable */
458
if(arg != NULL){
459
plugin *p = getplugin(arg);
460
if(p == NULL){
461
return ARGP_ERR_UNKNOWN;
462
}
463
p->disabled = true;
464
}
465
break;
466
case 'e': /* --enable */
467
if(arg != NULL){
468
plugin *p = getplugin(arg);
469
if(p == NULL){
470
return ARGP_ERR_UNKNOWN;
471
}
472
p->disabled = false;
473
}
474
break;
475
case 128: /* --plugin-dir */
476
free(plugindir);
477
plugindir = strdup(arg);
478
if(plugindir == NULL){
479
perror("strdup");
480
}
481
break;
482
case 129: /* --config-file */
483
/* This is already done by parse_opt_config_file() */
484
break;
485
case 130: /* --userid */
486
errno = 0;
487
tmpmax = strtoimax(arg, &tmp, 10);
488
if(errno != 0 or tmp == arg or *tmp != '\0'
489
or tmpmax != (uid_t)tmpmax){
490
fprintf(stderr, "Bad user ID number: \"%s\", using %"
491
PRIdMAX "\n", arg, (intmax_t)uid);
492
} else {
493
uid = (uid_t)tmpmax;
494
}
495
break;
496
case 131: /* --groupid */
497
errno = 0;
498
tmpmax = strtoimax(arg, &tmp, 10);
499
if(errno != 0 or tmp == arg or *tmp != '\0'
500
or tmpmax != (gid_t)tmpmax){
501
fprintf(stderr, "Bad group ID number: \"%s\", using %"
502
PRIdMAX "\n", arg, (intmax_t)gid);
503
} else {
504
gid = (gid_t)tmpmax;
505
}
506
break;
507
case 132: /* --debug */
211
error_t parse_opt (int key, char *arg, struct argp_state *state) {
212
/* Get the INPUT argument from `argp_parse', which we know is a
213
pointer to our plugin list pointer. */
214
plugin **plugins = state->input;
215
switch (key) {
216
case 'g':
217
if (arg != NULL){
218
char *p = strtok(arg, ",");
219
do{
220
addargument(getplugin(NULL, plugins), p);
221
p = strtok(NULL, ",");
222
} while (p != NULL);
223
}
224
break;
225
case 'o':
226
if (arg != NULL){
227
char *name = strtok(arg, ":");
228
char *p = strtok(NULL, ":");
229
if(p != NULL){
230
p = strtok(p, ",");
231
do{
232
addargument(getplugin(name, plugins), p);
233
p = strtok(NULL, ",");
234
} while (p != NULL);
235
}
236
}
237
break;
238
case 'd':
239
if (arg != NULL){
240
getplugin(arg, plugins)->disabled = true;
241
}
242
break;
243
case 128:
244
plugindir = arg;
245
break;
246
case 129:
247
uid = (uid_t)strtol(arg, NULL, 10);
248
break;
249
case 130:
250
gid = (gid_t)strtol(arg, NULL, 10);
251
break;
252
case 131:
508
253
debug = true;
509
254
break;
510
/*
511
* When adding more options before this line, remember to also add a
512
* "case" to the "parse_opt_config_file" function below.
513
*/
514
case ARGP_KEY_ARG:
515
/* Cryptsetup always passes an argument, which is an empty
516
string if "none" was specified in /etc/crypttab. So if
517
argument was empty, we ignore it silently. */
518
if(arg[0] != '\0'){
519
fprintf(stderr, "Ignoring unknown argument \"%s\"\n", arg);
520
}
521
break;
522
case ARGP_KEY_END:
523
break;
524
default:
525
return ARGP_ERR_UNKNOWN;
526
}
527
return 0;
528
}
529
530
/* This option parser is the same as parse_opt() above, except it
531
ignores everything but the --config-file option. */
532
error_t parse_opt_config_file(int key, char *arg,
533
__attribute__((unused))
534
struct argp_state *state){
535
switch(key){
536
case 'g': /* --global-options */
537
case 'G': /* --global-env */
538
case 'o': /* --options-for */
539
case 'E': /* --env-for */
540
case 'd': /* --disable */
541
case 'e': /* --enable */
542
case 128: /* --plugin-dir */
543
break;
544
case 129: /* --config-file */
545
free(argfile);
546
argfile = strdup(arg);
547
if(argfile == NULL){
548
perror("strdup");
549
}
550
break;
551
case 130: /* --userid */
552
case 131: /* --groupid */
553
case 132: /* --debug */
554
case ARGP_KEY_ARG:
555
case ARGP_KEY_END:
556
break;
557
default:
558
return ARGP_ERR_UNKNOWN;
559
}
560
return 0;
561
}
562
563
struct argp argp = { .options = options,
564
.parser = parse_opt_config_file,
565
.args_doc = "",
255
case ARGP_KEY_ARG:
256
if(plus_options != NULL or arg == NULL or arg[0] != '+'){
257
argp_usage (state);
258
}
259
plus_options = arg;
260
break;
261
case ARGP_KEY_END:
262
break;
263
default:
264
return ARGP_ERR_UNKNOWN;
265
}
266
return 0;
267
}
268
269
plugin *plugin_list = NULL;
270
271
struct argp argp = { .options = options, .parser = parse_opt,
272
.args_doc = "[+PLUS_SEPARATED_OPTIONS]",
566
273
.doc = "Mandos plugin runner -- Run plugins" };
567
274
568
/* Parse using parse_opt_config_file() in order to get the custom
569
config file location, if any. */
570
ret = argp_parse(&argp, argc, argv, ARGP_IN_ORDER, 0, NULL);
571
if(ret == ARGP_ERR_UNKNOWN){
572
fprintf(stderr, "Unknown error while parsing arguments\n");
573
exitstatus = EXIT_FAILURE;
574
goto fallback;
575
}
576
577
/* Reset to the normal argument parser */
578
argp.parser = parse_opt;
579
580
/* Open the configfile if available */
581
if(argfile == NULL){
582
conffp = fopen(AFILE, "r");
583
} else {
584
conffp = fopen(argfile, "r");
585
}
586
if(conffp != NULL){
587
char *org_line = NULL;
588
char *p, *arg, *new_arg, *line;
589
size_t size = 0;
590
const char whitespace_delims[] = " \r\t\f\v\n";
591
const char comment_delim[] = "#";
592
593
custom_argc = 1;
594
custom_argv = malloc(sizeof(char*) * 2);
595
if(custom_argv == NULL){
275
argp_parse (&argp, argc, argv, 0, 0, &plugin_list);
276
277
if(plus_options){
278
/* This is a mangled argument in the form of
279
"+--option+--other-option=parameter+--yet-another-option", etc */
280
/* Make new argc and argv vars, and call argp_parse() again. */
281
plus_options++; /* skip the first '+' character */
282
const char delims[] = "+";
283
char *arg;
284
int new_argc = 1;
285
plus_argv = malloc(sizeof(char*) * 2);
286
if(plus_argv == NULL){
596
287
perror("malloc");
597
288
exitstatus = EXIT_FAILURE;
598
goto fallback;
599
}
600
custom_argv[0] = argv[0];
601
custom_argv[1] = NULL;
602
603
/* for each line in the config file, strip whitespace and ignore
604
commented text */
605
while(true){
606
sret = getline(&org_line, &size, conffp);
607
if(sret == -1){
608
break;
609
}
610
611
line = org_line;
612
arg = strsep(&line, comment_delim);
613
while((p = strsep(&arg, whitespace_delims)) != NULL){
614
if(p[0] == '\0'){
615
continue;
616
}
617
new_arg = strdup(p);
618
if(new_arg == NULL){
619
perror("strdup");
620
exitstatus = EXIT_FAILURE;
621
free(org_line);
622
goto fallback;
623
}
624
625
custom_argc += 1;
626
custom_argv = realloc(custom_argv, sizeof(char *)
627
* ((unsigned int) custom_argc + 1));
628
if(custom_argv == NULL){
629
perror("realloc");
630
exitstatus = EXIT_FAILURE;
631
free(org_line);
632
goto fallback;
633
}
634
custom_argv[custom_argc-1] = new_arg;
635
custom_argv[custom_argc] = NULL;
636
}
637
}
638
do {
639
ret = fclose(conffp);
640
} while(ret == EOF and errno == EINTR);
641
if(ret == EOF){
642
perror("fclose");
643
exitstatus = EXIT_FAILURE;
644
goto fallback;
645
}
646
free(org_line);
647
} else {
648
/* Check for harmful errors and go to fallback. Other errors might
649
not affect opening plugins */
650
if(errno == EMFILE or errno == ENFILE or errno == ENOMEM){
651
perror("fopen");
652
exitstatus = EXIT_FAILURE;
653
goto fallback;
654
}
655
}
656
/* If there was any arguments from configuration file,
657
pass them to parser as command arguments */
658
if(custom_argv != NULL){
659
ret = argp_parse(&argp, custom_argc, custom_argv, ARGP_IN_ORDER,
660
0, NULL);
661
if(ret == ARGP_ERR_UNKNOWN){
662
fprintf(stderr, "Unknown error while parsing arguments\n");
663
exitstatus = EXIT_FAILURE;
664
goto fallback;
665
}
666
}
667
668
/* Parse actual command line arguments, to let them override the
669
config file */
670
ret = argp_parse(&argp, argc, argv, ARGP_IN_ORDER, 0, NULL);
671
if(ret == ARGP_ERR_UNKNOWN){
672
fprintf(stderr, "Unknown error while parsing arguments\n");
673
exitstatus = EXIT_FAILURE;
674
goto fallback;
289
goto end;
290
}
291
plus_argv[0] = argv[0];
292
plus_argv[1] = NULL;
293
arg = strtok(plus_options, delims); /* Get first argument */
294
while(arg != NULL){
295
new_argc++;
296
plus_argv = realloc(plus_argv, sizeof(char *)
297
* ((unsigned int) new_argc + 1));
298
if(plus_argv == NULL){
299
perror("malloc");
300
exitstatus = EXIT_FAILURE;
301
goto end;
302
}
303
plus_argv[new_argc-1] = arg;
304
plus_argv[new_argc] = NULL;
305
arg = strtok(NULL, delims); /* Get next argument */
306
}
307
argp_parse (&argp, new_argc, plus_argv, 0, 0, &plugin_list);
675
308
}
676
309
677
310
if(debug){
681
314
for(char **a = p->argv; *a != NULL; a++){
682
315
fprintf(stderr, "\tArg: %s\n", *a);
683
316
}
684
fprintf(stderr, "...and %d environment variables\n", p->envc);
685
for(char **a = p->environ; *a != NULL; a++){
686
fprintf(stderr, "\t%s\n", *a);
687
}
688
317
}
689
318
}
690
319
691
/* Strip permissions down to nobody */
320
ret = setuid(uid);
321
if (ret == -1){
322
perror("setuid");
323
}
324
692
325
setgid(gid);
693
if(ret == -1){
326
if (ret == -1){
694
327
perror("setgid");
695
328
}
696
ret = setuid(uid);
697
if(ret == -1){
698
perror("setuid");
699
}
700
701
if(plugindir == NULL){
702
dir = opendir(PDIR);
703
} else {
704
dir = opendir(plugindir);
705
}
706
329
330
dir = opendir(plugindir);
707
331
if(dir == NULL){
708
332
perror("Could not open plugin dir");
709
333
exitstatus = EXIT_FAILURE;
710
goto fallback;
334
goto end;
711
335
}
712
336
713
337
/* Set the FD_CLOEXEC flag on the directory, if possible */
718
342
if(ret < 0){
719
343
perror("set_cloexec_flag");
720
344
exitstatus = EXIT_FAILURE;
721
goto fallback;
345
goto end;
722
346
}
723
347
}
724
348
}
725
349
726
350
FD_ZERO(&rfds_all);
727
351
728
/* Read and execute any executable in the plugin directory*/
729
352
while(true){
730
do {
731
dirst = readdir(dir);
732
} while(dirst == NULL and errno == EINTR);
353
dirst = readdir(dir);
733
354
734
/* All directory entries have been processed */
355
// All directory entries have been processed
735
356
if(dirst == NULL){
736
if(errno == EBADF){
737
perror("readdir");
738
exitstatus = EXIT_FAILURE;
739
goto fallback;
740
}
741
357
break;
742
358
}
743
359
744
360
d_name_len = strlen(dirst->d_name);
745
361
746
/* Ignore dotfiles, backup files and other junk */
362
// Ignore dotfiles, backup files and other junk
747
363
{
748
364
bool bad_name = false;
749
365
751
367
752
368
const char const *bad_suffixes[] = { "~", "#", ".dpkg-new",
753
369
".dpkg-old",
754
".dpkg-bak",
755
370
".dpkg-divert", NULL };
756
371
for(const char **pre = bad_prefixes; *pre != NULL; pre++){
757
372
size_t pre_len = strlen(*pre);
765
380
break;
766
381
}
767
382
}
383
768
384
if(bad_name){
769
385
continue;
770
386
}
387
771
388
for(const char **suf = bad_suffixes; *suf != NULL; suf++){
772
389
size_t suf_len = strlen(*suf);
773
390
if((d_name_len >= suf_len)
787
404
}
788
405
}
789
406
790
char *filename;
791
if(plugindir == NULL){
792
ret = (int)TEMP_FAILURE_RETRY(asprintf(&filename, PDIR "/%s",
793
dirst->d_name));
794
} else {
795
ret = (int)TEMP_FAILURE_RETRY(asprintf(&filename, "%s/%s",
796
plugindir,
797
dirst->d_name));
798
}
799
if(ret < 0){
800
perror("asprintf");
801
continue;
802
}
803
804
ret = (int)TEMP_FAILURE_RETRY(stat(filename, &st));
805
if(ret == -1){
806
perror("stat");
807
free(filename);
808
continue;
809
}
810
811
/* Ignore non-executable files */
812
if(not S_ISREG(st.st_mode)
813
or (TEMP_FAILURE_RETRY(access(filename, X_OK)) != 0)){
407
char *filename = malloc(d_name_len + strlen(plugindir) + 2);
408
if (filename == NULL){
409
perror("malloc");
410
exitstatus = EXIT_FAILURE;
411
goto end;
412
}
413
strcpy(filename, plugindir); /* Spurious warning */
414
strcat(filename, "/"); /* Spurious warning */
415
strcat(filename, dirst->d_name); /* Spurious warning */
416
417
stat(filename, &st);
418
419
if (not S_ISREG(st.st_mode) or (access(filename, X_OK) != 0)){
814
420
if(debug){
815
421
fprintf(stderr, "Ignoring plugin dir entry \"%s\""
816
422
" with bad type or mode\n", filename);
818
424
free(filename);
819
425
continue;
820
426
}
821
822
plugin *p = getplugin(dirst->d_name);
823
if(p == NULL){
824
perror("getplugin");
825
free(filename);
826
continue;
827
}
828
if(p->disabled){
427
if(getplugin(dirst->d_name, &plugin_list)->disabled){
829
428
if(debug){
830
429
fprintf(stderr, "Ignoring disabled plugin \"%s\"\n",
831
430
dirst->d_name);
833
432
free(filename);
834
433
continue;
835
434
}
435
plugin *p = getplugin(dirst->d_name, &plugin_list);
836
436
{
837
437
/* Add global arguments to argument list for this plugin */
838
plugin *g = getplugin(NULL);
839
if(g != NULL){
840
for(char **a = g->argv + 1; *a != NULL; a++){
841
if(not add_argument(p, *a)){
842
perror("add_argument");
843
}
844
}
845
/* Add global environment variables */
846
for(char **e = g->environ; *e != NULL; e++){
847
if(not add_environment(p, *e, false)){
848
perror("add_environment");
849
}
850
}
851
}
852
}
853
/* If this plugin has any environment variables, we will call
854
using execve and need to duplicate the environment from this
855
process, too. */
856
if(p->environ[0] != NULL){
857
for(char **e = environ; *e != NULL; e++){
858
if(not add_environment(p, *e, false)){
859
perror("add_environment");
860
}
861
}
862
}
863
864
int pipefd[2];
865
ret = (int)TEMP_FAILURE_RETRY(pipe(pipefd));
866
if(ret == -1){
438
plugin *g = getplugin(NULL, &plugin_list);
439
for(char **a = g->argv + 1; *a != NULL; a++){
440
addargument(p, *a);
441
}
442
}
443
int pipefd[2];
444
ret = pipe(pipefd);
445
if (ret == -1){
867
446
perror("pipe");
868
447
exitstatus = EXIT_FAILURE;
869
goto fallback;
448
goto end;
870
449
}
871
/* Ask OS to automatic close the pipe on exec */
872
450
ret = set_cloexec_flag(pipefd[0]);
873
451
if(ret < 0){
874
452
perror("set_cloexec_flag");
875
453
exitstatus = EXIT_FAILURE;
876
goto fallback;
454
goto end;
877
455
}
878
456
ret = set_cloexec_flag(pipefd[1]);
879
457
if(ret < 0){
880
458
perror("set_cloexec_flag");
881
459
exitstatus = EXIT_FAILURE;
882
goto fallback;
460
goto end;
883
461
}
884
462
/* Block SIGCHLD until process is safely in process list */
885
ret = (int)TEMP_FAILURE_RETRY(sigprocmask(SIG_BLOCK,
886
&sigchld_action.sa_mask,
887
NULL));
463
ret = sigprocmask (SIG_BLOCK, &sigchld_action.sa_mask, NULL);
888
464
if(ret < 0){
889
465
perror("sigprocmask");
890
466
exitstatus = EXIT_FAILURE;
891
goto fallback;
892
}
893
/* Starting a new process to be watched */
894
pid_t pid;
895
do {
896
pid = fork();
897
} while(pid == -1 and errno == EINTR);
898
if(pid == -1){
899
perror("fork");
900
exitstatus = EXIT_FAILURE;
901
goto fallback;
902
}
467
goto end;
468
}
469
// Starting a new process to be watched
470
pid_t pid = fork();
903
471
if(pid == 0){
904
472
/* this is the child process */
905
473
ret = sigaction(SIGCHLD, &old_sigchld_action, NULL);
907
475
perror("sigaction");
908
476
_exit(EXIT_FAILURE);
909
477
}
910
ret = sigprocmask(SIG_UNBLOCK, &sigchld_action.sa_mask, NULL);
478
ret = sigprocmask (SIG_UNBLOCK, &sigchld_action.sa_mask, NULL);
911
479
if(ret < 0){
912
480
perror("sigprocmask");
913
481
_exit(EXIT_FAILURE);
914
482
}
915
916
ret = dup2(pipefd[1], STDOUT_FILENO); /* replace our stdout */
917
if(ret == -1){
918
perror("dup2");
919
_exit(EXIT_FAILURE);
920
}
483
dup2(pipefd[1], STDOUT_FILENO); /* replace our stdout */
921
484
922
485
if(dirfd(dir) < 0){
923
486
/* If dir has no file descriptor, we could not set FD_CLOEXEC
924
487
above and must now close it manually here. */
925
488
closedir(dir);
926
489
}
927
if(p->environ[0] == NULL){
928
if(execv(filename, p->argv) < 0){
929
perror("execv");
930
_exit(EXIT_FAILURE);
931
}
932
} else {
933
if(execve(filename, p->argv, p->environ) < 0){
934
perror("execve");
935
_exit(EXIT_FAILURE);
936
}
490
if(execv(filename, p->argv) < 0){
491
perror("execv");
492
_exit(EXIT_FAILURE);
937
493
}
938
494
/* no return */
939
495
}
940
/* Parent process */
941
TEMP_FAILURE_RETRY(close(pipefd[1])); /* Close unused write end of
942
pipe */
496
/* parent process */
943
497
free(filename);
944
plugin *new_plugin = getplugin(dirst->d_name);
945
if(new_plugin == NULL){
946
perror("getplugin");
947
ret = (int)(TEMP_FAILURE_RETRY
948
(sigprocmask(SIG_UNBLOCK, &sigchld_action.sa_mask,
949
NULL)));
498
close(pipefd[1]); /* close unused write end of pipe */
499
process *new_process = malloc(sizeof(process));
500
if (new_process == NULL){
501
perror("malloc");
502
ret = sigprocmask (SIG_UNBLOCK, &sigchld_action.sa_mask, NULL);
950
503
if(ret < 0){
951
perror("sigprocmask");
504
perror("sigprocmask");
952
505
}
953
506
exitstatus = EXIT_FAILURE;
954
goto fallback;
507
goto end;
955
508
}
956
509
957
new_plugin->pid = pid;
958
new_plugin->fd = pipefd[0];
959
510
*new_process = (struct process){ .pid = pid,
511
.fd = pipefd[0],
512
.next = process_list };
513
// List handling
514
process_list = new_process;
960
515
/* Unblock SIGCHLD so signal handler can be run if this process
961
516
has already completed */
962
ret = (int)TEMP_FAILURE_RETRY(sigprocmask(SIG_UNBLOCK,
963
&sigchld_action.sa_mask,
964
NULL));
517
ret = sigprocmask (SIG_UNBLOCK, &sigchld_action.sa_mask, NULL);
965
518
if(ret < 0){
966
519
perror("sigprocmask");
967
520
exitstatus = EXIT_FAILURE;
968
goto fallback;
969
}
970
971
FD_SET(new_plugin->fd, &rfds_all); /* Spurious warning from
972
-Wconversion */
973
974
if(maxfd < new_plugin->fd){
975
maxfd = new_plugin->fd;
976
}
977
}
978
979
TEMP_FAILURE_RETRY(closedir(dir));
521
goto end;
522
}
523
524
FD_SET(new_process->fd, &rfds_all);
525
526
if (maxfd < new_process->fd){
527
maxfd = new_process->fd;
528
}
529
530
}
531
532
/* Free the plugin list */
533
for(plugin *next; plugin_list != NULL; plugin_list = next){
534
next = plugin_list->next;
535
free(plugin_list->argv);
536
free(plugin_list);
537
}
538
539
closedir(dir);
980
540
dir = NULL;
981
free_plugin(getplugin(NULL));
982
541
983
for(plugin *p = plugin_list; p != NULL; p = p->next){
984
if(p->pid != 0){
985
break;
986
}
987
if(p->next == NULL){
988
fprintf(stderr, "No plugin processes started. Incorrect plugin"
989
" directory?\n");
990
free_plugin_list();
991
}
542
if (process_list == NULL){
543
fprintf(stderr, "No plugin processes started, exiting\n");
544
exitstatus = EXIT_FAILURE;
545
goto end;
992
546
}
993
994
/* Main loop while running plugins exist */
995
while(plugin_list){
547
while(process_list){
996
548
fd_set rfds = rfds_all;
997
549
int select_ret = select(maxfd+1, &rfds, NULL, NULL, NULL);
998
if(select_ret == -1 and errno != EINTR){
550
if (select_ret == -1){
999
551
perror("select");
1000
552
exitstatus = EXIT_FAILURE;
1001
goto fallback;
553
goto end;
1002
554
}
1003
555
/* OK, now either a process completed, or something can be read
1004
556
from one of them */
1005
for(plugin *proc = plugin_list; proc != NULL;){
557
for(process *proc = process_list; proc ; proc = proc->next){
1006
558
/* Is this process completely done? */
1007
if(proc->completed and proc->eof){
559
if(proc->eof and proc->completed){
1008
560
/* Only accept the plugin output if it exited cleanly */
1009
561
if(not WIFEXITED(proc->status)
1010
562
or WEXITSTATUS(proc->status) != 0){
1011
563
/* Bad exit by plugin */
1012
1013
564
if(debug){
1014
565
if(WIFEXITED(proc->status)){
1015
fprintf(stderr, "Plugin %s [%" PRIdMAX "] exited with"
1016
" status %d\n", proc->name,
1017
(intmax_t) (proc->pid),
1018
WEXITSTATUS(proc->status));
1019
} else if(WIFSIGNALED(proc->status)){
1020
fprintf(stderr, "Plugin %s [%" PRIdMAX "] killed by"
1021
" signal %d: %s\n", proc->name,
1022
(intmax_t) (proc->pid),
1023
WTERMSIG(proc->status),
1024
strsignal(WTERMSIG(proc->status)));
566
fprintf(stderr, "Plugin %d exited with status %d\n",
567
proc->pid, WEXITSTATUS(proc->status));
568
} else if(WIFSIGNALED(proc->status)) {
569
fprintf(stderr, "Plugin %d killed by signal %d\n",
570
proc->pid, WTERMSIG(proc->status));
1025
571
} else if(WCOREDUMP(proc->status)){
1026
fprintf(stderr, "Plugin %s [%" PRIdMAX "] dumped"
1027
" core\n", proc->name, (intmax_t) (proc->pid));
572
fprintf(stderr, "Plugin %d dumped core\n", proc->pid);
1028
573
}
1029
574
}
1030
1031
575
/* Remove the plugin */
1032
FD_CLR(proc->fd, &rfds_all); /* Spurious warning from
1033
-Wconversion */
1034
576
FD_CLR(proc->fd, &rfds_all);
1035
577
/* Block signal while modifying process_list */
1036
ret = (int)TEMP_FAILURE_RETRY(sigprocmask
1037
(SIG_BLOCK,
1038
&sigchld_action.sa_mask,
1039
NULL));
578
ret = sigprocmask (SIG_BLOCK, &sigchld_action.sa_mask, NULL);
1040
579
if(ret < 0){
1041
580
perror("sigprocmask");
1042
581
exitstatus = EXIT_FAILURE;
1043
goto fallback;
1044
}
1045
1046
plugin *next_plugin = proc->next;
1047
free_plugin(proc);
1048
proc = next_plugin;
1049
582
goto end;
583
}
584
/* Delete this process entry from the list */
585
if(process_list == proc){
586
/* First one - simple */
587
process_list = proc->next;
588
} else {
589
/* Second one or later */
590
for(process *p = process_list; p != NULL; p = p->next){
591
if(p->next == proc){
592
p->next = proc->next;
593
break;
594
}
595
}
596
}
1050
597
/* We are done modifying process list, so unblock signal */
1051
ret = (int)(TEMP_FAILURE_RETRY
1052
(sigprocmask(SIG_UNBLOCK,
1053
&sigchld_action.sa_mask, NULL)));
598
ret = sigprocmask (SIG_UNBLOCK, &sigchld_action.sa_mask,
599
NULL);
1054
600
if(ret < 0){
1055
601
perror("sigprocmask");
1056
exitstatus = EXIT_FAILURE;
1057
goto fallback;
1058
}
1059
1060
if(plugin_list == NULL){
1061
break;
1062
}
1063
1064
continue;
602
}
603
free(proc->buffer);
604
free(proc);
605
/* We deleted this process from the list, so we can't go
606
proc->next. Therefore, start over from the beginning of
607
the process list */
608
break;
1065
609
}
1066
1067
610
/* This process exited nicely, so print its buffer */
1068
1069
bool bret = print_out_password(proc->buffer,
1070
proc->buffer_length);
1071
if(not bret){
1072
perror("print_out_password");
1073
exitstatus = EXIT_FAILURE;
611
for(size_t written = 0; written < proc->buffer_length;
612
written += (size_t)ret){
613
ret = TEMP_FAILURE_RETRY(write(STDOUT_FILENO,
614
proc->buffer + written,
615
proc->buffer_length
616
- written));
617
if(ret < 0){
618
perror("write");
619
exitstatus = EXIT_FAILURE;
620
goto end;
621
}
1074
622
}
1075
goto fallback;
623
goto end;
1076
624
}
1077
1078
625
/* This process has not completed. Does it have any output? */
1079
if(proc->eof or not FD_ISSET(proc->fd, &rfds)){ /* Spurious
1080
warning from
1081
-Wconversion */
626
if(proc->eof or not FD_ISSET(proc->fd, &rfds)){
1082
627
/* This process had nothing to say at this time */
1083
proc = proc->next;
1084
628
continue;
1085
629
}
1086
630
/* Before reading, make the process' data buffer large enough */
1087
631
if(proc->buffer_length + BUFFER_SIZE > proc->buffer_size){
1088
632
proc->buffer = realloc(proc->buffer, proc->buffer_size
1089
633
+ (size_t) BUFFER_SIZE);
1090
if(proc->buffer == NULL){
634
if (proc->buffer == NULL){
1091
635
perror("malloc");
1092
636
exitstatus = EXIT_FAILURE;
1093
goto fallback;
637
goto end;
1094
638
}
1095
639
proc->buffer_size += BUFFER_SIZE;
1096
640
}
1097
641
/* Read from the process */
1098
sret = TEMP_FAILURE_RETRY(read(proc->fd,
1099
proc->buffer
1100
+ proc->buffer_length,
1101
BUFFER_SIZE));
1102
if(sret < 0){
642
ret = read(proc->fd, proc->buffer + proc->buffer_length,
643
BUFFER_SIZE);
644
if(ret < 0){
1103
645
/* Read error from this process; ignore the error */
1104
proc = proc->next;
1105
646
continue;
1106
647
}
1107
if(sret == 0){
648
if(ret == 0){
1108
649
/* got EOF */
1109
650
proc->eof = true;
1110
651
} else {
1111
proc->buffer_length += (size_t) sret;
652
proc->buffer_length += (size_t) ret;
1112
653
}
1113
654
}
1114
655
}
1115
1116
1117
fallback:
1118
1119
if(plugin_list == NULL or exitstatus != EXIT_SUCCESS){
1120
/* Fallback if all plugins failed, none are found or an error
1121
occured */
1122
bool bret;
1123
fprintf(stderr, "Going to fallback mode using getpass(3)\n");
1124
char *passwordbuffer = getpass("Password: ");
1125
size_t len = strlen(passwordbuffer);
1126
/* Strip trailing newline */
1127
if(len > 0 and passwordbuffer[len-1] == '\n'){
1128
passwordbuffer[len-1] = '\0'; /* not strictly necessary */
1129
len--;
1130
}
1131
bret = print_out_password(passwordbuffer, len);
1132
if(not bret){
1133
perror("print_out_password");
1134
exitstatus = EXIT_FAILURE;
1135
}
656
if(process_list == NULL){
657
fprintf(stderr, "All plugin processes failed, exiting\n");
658
exitstatus = EXIT_FAILURE;
1136
659
}
1137
660
661
end:
1138
662
/* Restore old signal handler */
1139
ret = sigaction(SIGCHLD, &old_sigchld_action, NULL);
1140
if(ret == -1){
1141
perror("sigaction");
1142
exitstatus = EXIT_FAILURE;
1143
}
1144
1145
if(custom_argv != NULL){
1146
for(char **arg = custom_argv+1; *arg != NULL; arg++){
1147
free(*arg);
1148
}
1149
free(custom_argv);
663
sigaction(SIGCHLD, &old_sigchld_action, NULL);
664
665
free(plus_argv);
666
667
/* Free the plugin list */
668
for(plugin *next; plugin_list != NULL; plugin_list = next){
669
next = plugin_list->next;
670
free(plugin_list->argv);
671
free(plugin_list);
1150
672
}
1151
673
1152
674
if(dir != NULL){
1153
675
closedir(dir);
1154
676
}
1155
677
1156
/* Kill the processes */
1157
for(plugin *p = plugin_list; p != NULL; p = p->next){
1158
if(p->pid != 0){
1159
close(p->fd);
1160
ret = kill(p->pid, SIGTERM);
1161
if(ret == -1 and errno != ESRCH){
1162
/* Set-uid proccesses might not get closed */
1163
perror("kill");
1164
}
1165
}
678
/* Free the process list and kill the processes */
679
for(process *next; process_list != NULL; process_list = next){
680
next = process_list->next;
681
close(process_list->fd);
682
kill(process_list->pid, SIGTERM);
683
free(process_list->buffer);
684
free(process_list);
1166
685
}
1167
686
1168
687
/* Wait for any remaining child processes to terminate */
1169
do {
688
do{
1170
689
ret = wait(NULL);
1171
690
} while(ret >= 0);
1172
691
if(errno != ECHILD){
1173
692
perror("wait");
1174
693
}
1175
694
1176
free_plugin_list();
1177
1178
free(plugindir);
1179
free(argfile);
1180
1181
695
return exitstatus;
1182
696
}
Loggerhead is a web-based interface for Breezy
Version: 2.0.2.dev0