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