To get this branch, use:
bzr branch
http://bzr.recompile.se/loggerhead/mandos/trunk
« back to all changes in this revision
Viewing changes to plugins.d/usplash.c
- browse files at revision 1237
- compare with another revision
- download diff
- download tarball
- view history from revision 1237
- Committer: Teddy Hogeborn
- Date: 2021-02-03 23:10:42 UTC
- Revision ID: teddy@recompile.se-20210203231042-2z3egrvpo1zt7nej
mandos-ctl: Fix bad test for command.Remove and related minor issues
The test for command.Remove removes all clients from the spy server,
and then loops over all clients, looking for the corresponding Remove
command as recorded by the spy server. But since since there aren't
any clients left after they were removed, no assertions are made, and
the test therefore does nothing. Fix this.
In tests for command.Approve and command.Deny, add checks that clients
were not somehow removed by the command (in which case, likewise, no
assertions are made).
Add related checks to TestPropertySetterCmd.runTest; i.e. test that a
sequence is not empty before looping over it and making assertions.
* mandos-ctl (TestBaseCommands.test_Remove): Save a copy of the
original "clients" dict, and loop over those instead. Add assertion
that all clients were indeed removed. Also fix the code which looks
for the Remove command, which now needs to actually work.
(TestBaseCommands.test_Approve, TestBaseCommands.test_Deny): Add
assertion that there are still clients before looping over them.
(TestPropertySetterCmd.runTest): Add assertion that the list of
values to get is not empty before looping over them. Also add check
that there are still clients before looping over clients.
The test for command.Remove removes all clients from the spy server,
and then loops over all clients, looking for the corresponding Remove
command as recorded by the spy server. But since since there aren't
any clients left after they were removed, no assertions are made, and
the test therefore does nothing. Fix this.
In tests for command.Approve and command.Deny, add checks that clients
were not somehow removed by the command (in which case, likewise, no
assertions are made).
Add related checks to TestPropertySetterCmd.runTest; i.e. test that a
sequence is not empty before looping over it and making assertions.
* mandos-ctl (TestBaseCommands.test_Remove): Save a copy of the
original "clients" dict, and loop over those instead. Add assertion
that all clients were indeed removed. Also fix the code which looks
for the Remove command, which now needs to actually work.
(TestBaseCommands.test_Approve, TestBaseCommands.test_Deny): Add
assertion that there are still clients before looping over them.
(TestPropertySetterCmd.runTest): Add assertion that the list of
values to get is not empty before looping over them. Also add check
that there are still clients before looping over clients.
- files added:
- DBUS-API
- debian/source
- debian/tests
- debian/upstream
- dracut-module
- network-hooks.d
- plugin-helpers
- files removed:
- debian/mandos-client.config
- files modified:
- .bzrignore
added
removed
plugins.d/usplash.c
1
#define _GNU_SOURCE /* asprintf() */
2
#include <signal.h> /* sig_atomic_t, struct sigaction,
3
sigemptyset(), sigaddset(), SIGINT,
4
SIGHUP, SIGTERM, sigaction(),
5
SIG_IGN, kill(), SIGKILL */
1
/* -*- coding: utf-8 -*- */
2
/*
3
* Usplash - Read a password from usplash and output it
4
*
5
* Copyright © 2008-2018, 2021 Teddy Hogeborn
6
* Copyright © 2008-2018, 2021 Björn Påhlsson
7
*
8
* This file is part of Mandos.
9
*
10
* Mandos is free software: you can redistribute it and/or modify it
11
* under the terms of the GNU General Public License as published by
12
* the Free Software Foundation, either version 3 of the License, or
13
* (at your option) any later version.
14
*
15
* Mandos is distributed in the hope that it will be useful, but
16
* WITHOUT ANY WARRANTY; without even the implied warranty of
17
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
18
* General Public License for more details.
19
*
20
* You should have received a copy of the GNU General Public License
21
* along with Mandos. If not, see <http://www.gnu.org/licenses/>.
22
*
23
* Contact the authors at <mandos@recompile.se>.
24
*/
25
26
#define _GNU_SOURCE /* vasprintf(),
27
program_invocation_short_name,
28
asprintf(), TEMP_FAILURE_RETRY() */
29
#include <sys/types.h> /* sig_atomic_t, pid_t, setuid(),
30
geteuid(), setsid() */
31
#include <stdarg.h> /* va_list, va_start(), vfprintf() */
32
#include <stdio.h> /* vasprintf(), fprintf(), stderr,
33
vfprintf(), asprintf() */
34
#include <errno.h> /* program_invocation_short_name,
35
errno, ENOENT, EINTR */
36
#include <string.h> /* strerror(), strlen(), memcmp() */
37
#include <error.h> /* error() */
38
#include <stdlib.h> /* free(), getenv(), realloc(),
39
EXIT_FAILURE, EXIT_SUCCESS,
40
malloc(), abort() */
6
41
#include <stdbool.h> /* bool, false, true */
7
42
#include <fcntl.h> /* open(), O_WRONLY, O_RDONLY */
8
#include <iso646.h> /* and, or, not*/
9
#include <errno.h> /* errno, EINTR */
10
#include <sys/types.h> /* size_t, ssize_t, pid_t, DIR, struct
11
dirent */
12
#include <stddef.h> /* NULL */
13
#include <string.h> /* strlen(), memcmp() */
14
#include <stdio.h> /* asprintf(), perror() */
15
#include <unistd.h> /* close(), write(), readlink(),
16
read(), STDOUT_FILENO, sleep(),
17
fork(), setuid(), geteuid(),
18
setsid(), chdir(), dup2(),
19
STDERR_FILENO, execv() */
20
#include <stdlib.h> /* free(), EXIT_FAILURE, strtoul(),
21
realloc(), EXIT_SUCCESS, malloc(),
22
_exit() */
23
#include <stdlib.h> /* getenv() */
24
#include <dirent.h> /* opendir(), readdir(), closedir() */
25
#include <sys/stat.h> /* struct stat, lstat(), S_ISLNK */
43
#include <stddef.h> /* size_t, NULL */
44
#include <unistd.h> /* close(), ssize_t, write(),
45
readlink(), read(), STDOUT_FILENO,
46
sleep(), fork(), setuid(),
47
geteuid(), setsid(), chdir(),
48
_exit(), dup2(), STDERR_FILENO,
49
execv(), TEMP_FAILURE_RETRY(),
50
pause() */
51
#include <dirent.h> /* DIR, opendir(), struct dirent,
52
readdir(), closedir() */
53
#include <inttypes.h> /* intmax_t, strtoimax() */
54
#include <iso646.h> /* or, not, and */
55
#include <sys/stat.h> /* struct stat, lstat(), S_ISLNK() */
56
#include <sysexits.h> /* EX_OSERR, EX_UNAVAILABLE */
57
#include <signal.h> /* struct sigaction, sigemptyset(),
58
sigaddset(), SIGINT, SIGHUP,
59
SIGTERM, SIG_IGN, kill(), SIGKILL,
60
SIG_DFL, raise() */
61
#include <argz.h> /* argz_count(), argz_extract() */
26
62
27
63
sig_atomic_t interrupted_by_signal = 0;
28
29
static void termination_handler(__attribute__((unused))int signum){
64
int signal_received;
65
const char usplash_name[] = "/sbin/usplash";
66
67
/* Function to use when printing errors */
68
__attribute__((format (gnu_printf, 3, 4)))
69
void error_plus(int status, int errnum, const char *formatstring,
70
...){
71
va_list ap;
72
char *text;
73
int ret;
74
75
va_start(ap, formatstring);
76
ret = vasprintf(&text, formatstring, ap);
77
if(ret == -1){
78
fprintf(stderr, "Mandos plugin %s: ",
79
program_invocation_short_name);
80
vfprintf(stderr, formatstring, ap);
81
fprintf(stderr, ": ");
82
fprintf(stderr, "%s\n", strerror(errnum));
83
error(status, errno, "vasprintf while printing error");
84
return;
85
}
86
fprintf(stderr, "Mandos plugin ");
87
error(status, errnum, "%s", text);
88
free(text);
89
}
90
91
static void termination_handler(int signum){
92
if(interrupted_by_signal){
93
return;
94
}
30
95
interrupted_by_signal = 1;
96
signal_received = signum;
31
97
}
32
98
33
static bool usplash_write(const char *cmd, const char *arg){
99
static bool usplash_write(int *fifo_fd_r,
100
const char *cmd, const char *arg){
34
101
/*
35
* usplash_write("TIMEOUT", "15") will write "TIMEOUT 15\0"
36
* usplash_write("PULSATE", NULL) will write "PULSATE\0"
102
* usplash_write(&fd, "TIMEOUT", "15") will write "TIMEOUT 15\0"
103
* usplash_write(&fd, "PULSATE", NULL) will write "PULSATE\0"
37
104
* SEE ALSO
38
105
* usplash_write(8)
39
106
*/
40
107
int ret;
41
int fifo_fd;
42
do{
43
fifo_fd = open("/dev/.initramfs/usplash_fifo", O_WRONLY);
44
if(fifo_fd == -1 and (errno != EINTR or interrupted_by_signal)){
108
if(*fifo_fd_r == -1){
109
ret = open("/dev/.initramfs/usplash_fifo", O_WRONLY);
110
if(ret == -1){
45
111
return false;
46
112
}
47
}while(fifo_fd == -1);
113
*fifo_fd_r = ret;
114
}
48
115
49
116
const char *cmd_line;
50
117
size_t cmd_line_len;
51
118
char *cmd_line_alloc = NULL;
52
119
if(arg == NULL){
53
120
cmd_line = cmd;
54
cmd_line_len = strlen(cmd);
55
}else{
56
do{
121
cmd_line_len = strlen(cmd) + 1;
122
} else {
123
do {
57
124
ret = asprintf(&cmd_line_alloc, "%s %s", cmd, arg);
58
if(ret == -1 and (errno != EINTR or interrupted_by_signal)){
125
if(ret == -1){
59
126
int e = errno;
60
close(fifo_fd);
127
close(*fifo_fd_r);
61
128
errno = e;
62
129
return false;
63
130
}
64
}while(ret == -1);
131
} while(ret == -1);
65
132
cmd_line = cmd_line_alloc;
66
133
cmd_line_len = (size_t)ret + 1;
67
134
}
68
135
69
136
size_t written = 0;
70
while(not interrupted_by_signal and written < cmd_line_len){
71
ret = write(fifo_fd, cmd_line + written,
72
cmd_line_len - written);
73
if(ret == -1){
74
if(errno != EINTR or interrupted_by_signal){
75
int e = errno;
76
close(fifo_fd);
77
free(cmd_line_alloc);
78
errno = e;
79
return false;
80
} else {
81
continue;
82
}
137
ssize_t sret = 0;
138
while(written < cmd_line_len){
139
sret = write(*fifo_fd_r, cmd_line + written,
140
cmd_line_len - written);
141
if(sret == -1){
142
int e = errno;
143
close(*fifo_fd_r);
144
free(cmd_line_alloc);
145
errno = e;
146
return false;
83
147
}
84
written += (size_t)ret;
148
written += (size_t)sret;
85
149
}
86
150
free(cmd_line_alloc);
87
do{
88
ret = close(fifo_fd);
89
if(ret == -1 and (errno != EINTR or interrupted_by_signal)){
90
return false;
91
}
92
}while(ret == -1);
93
if(interrupted_by_signal){
94
return false;
95
}
151
96
152
return true;
97
153
}
98
154
155
/* Create prompt string */
156
char *makeprompt(void){
157
int ret = 0;
158
char *prompt;
159
const char *const cryptsource = getenv("cryptsource");
160
const char *const crypttarget = getenv("crypttarget");
161
const char prompt_start[] = "Enter passphrase to unlock the disk";
162
163
if(cryptsource == NULL){
164
if(crypttarget == NULL){
165
ret = asprintf(&prompt, "%s: ", prompt_start);
166
} else {
167
ret = asprintf(&prompt, "%s (%s): ", prompt_start,
168
crypttarget);
169
}
170
} else {
171
if(crypttarget == NULL){
172
ret = asprintf(&prompt, "%s %s: ", prompt_start, cryptsource);
173
} else {
174
ret = asprintf(&prompt, "%s %s (%s): ", prompt_start,
175
cryptsource, crypttarget);
176
}
177
}
178
if(ret == -1){
179
return NULL;
180
}
181
return prompt;
182
}
183
184
pid_t find_usplash(char **cmdline_r, size_t *cmdline_len_r){
185
int ret = 0;
186
ssize_t sret = 0;
187
char *cmdline = NULL;
188
size_t cmdline_len = 0;
189
DIR *proc_dir = opendir("/proc");
190
if(proc_dir == NULL){
191
error_plus(0, errno, "opendir");
192
return -1;
193
}
194
errno = 0;
195
for(struct dirent *proc_ent = readdir(proc_dir);
196
proc_ent != NULL;
197
proc_ent = readdir(proc_dir)){
198
pid_t pid;
199
{
200
intmax_t tmpmax;
201
char *tmp;
202
tmpmax = strtoimax(proc_ent->d_name, &tmp, 10);
203
if(errno != 0 or tmp == proc_ent->d_name or *tmp != '\0'
204
or tmpmax != (pid_t)tmpmax){
205
/* Not a process */
206
errno = 0;
207
continue;
208
}
209
pid = (pid_t)tmpmax;
210
}
211
/* Find the executable name by doing readlink() on the
212
/proc/<pid>/exe link */
213
char exe_target[sizeof(usplash_name)];
214
{
215
/* create file name string */
216
char *exe_link;
217
ret = asprintf(&exe_link, "/proc/%s/exe", proc_ent->d_name);
218
if(ret == -1){
219
error_plus(0, errno, "asprintf");
220
goto fail_find_usplash;
221
}
222
223
/* Check that it refers to a symlink owned by root:root */
224
struct stat exe_stat;
225
ret = lstat(exe_link, &exe_stat);
226
if(ret == -1){
227
if(errno == ENOENT){
228
free(exe_link);
229
continue;
230
}
231
error_plus(0, errno, "lstat");
232
free(exe_link);
233
goto fail_find_usplash;
234
}
235
if(not S_ISLNK(exe_stat.st_mode)
236
or exe_stat.st_uid != 0
237
or exe_stat.st_gid != 0){
238
free(exe_link);
239
continue;
240
}
241
242
sret = readlink(exe_link, exe_target, sizeof(exe_target));
243
free(exe_link);
244
}
245
/* Compare executable name */
246
if((sret != ((ssize_t)sizeof(exe_target)-1))
247
or (memcmp(usplash_name, exe_target,
248
sizeof(exe_target)-1) != 0)){
249
/* Not it */
250
continue;
251
}
252
/* Found usplash */
253
/* Read and save the command line of usplash in "cmdline" */
254
{
255
/* Open /proc/<pid>/cmdline */
256
int cl_fd;
257
{
258
char *cmdline_filename;
259
ret = asprintf(&cmdline_filename, "/proc/%s/cmdline",
260
proc_ent->d_name);
261
if(ret == -1){
262
error_plus(0, errno, "asprintf");
263
goto fail_find_usplash;
264
}
265
cl_fd = open(cmdline_filename, O_RDONLY);
266
free(cmdline_filename);
267
if(cl_fd == -1){
268
error_plus(0, errno, "open");
269
goto fail_find_usplash;
270
}
271
}
272
size_t cmdline_allocated = 0;
273
char *tmp;
274
const size_t blocksize = 1024;
275
do {
276
/* Allocate more space? */
277
if(cmdline_len + blocksize > cmdline_allocated){
278
tmp = realloc(cmdline, cmdline_allocated + blocksize);
279
if(tmp == NULL){
280
error_plus(0, errno, "realloc");
281
close(cl_fd);
282
goto fail_find_usplash;
283
}
284
cmdline = tmp;
285
cmdline_allocated += blocksize;
286
}
287
/* Read data */
288
sret = read(cl_fd, cmdline + cmdline_len,
289
cmdline_allocated - cmdline_len);
290
if(sret == -1){
291
error_plus(0, errno, "read");
292
close(cl_fd);
293
goto fail_find_usplash;
294
}
295
cmdline_len += (size_t)sret;
296
} while(sret != 0);
297
ret = close(cl_fd);
298
if(ret == -1){
299
error_plus(0, errno, "close");
300
goto fail_find_usplash;
301
}
302
}
303
/* Close directory */
304
ret = closedir(proc_dir);
305
if(ret == -1){
306
error_plus(0, errno, "closedir");
307
goto fail_find_usplash;
308
}
309
/* Success */
310
*cmdline_r = cmdline;
311
*cmdline_len_r = cmdline_len;
312
return pid;
313
}
314
315
fail_find_usplash:
316
317
free(cmdline);
318
if(proc_dir != NULL){
319
int e = errno;
320
closedir(proc_dir);
321
errno = e;
322
}
323
return 0;
324
}
325
99
326
int main(__attribute__((unused))int argc,
100
327
__attribute__((unused))char **argv){
101
328
int ret = 0;
102
329
ssize_t sret;
103
bool an_error_occured = false;
330
int fifo_fd = -1;
331
int outfifo_fd = -1;
332
char *buf = NULL;
333
size_t buf_len = 0;
334
pid_t usplash_pid = -1;
335
bool usplash_accessed = false;
336
int status = EXIT_FAILURE; /* Default failure exit status */
104
337
105
/* Create prompt string */
106
char *prompt = NULL;
107
{
108
const char *const cryptsource = getenv("cryptsource");
109
const char *const crypttarget = getenv("crypttarget");
110
const char prompt_start[] = "Enter passphrase to unlock the disk";
111
112
if(cryptsource == NULL){
113
if(crypttarget == NULL){
114
ret = asprintf(&prompt, "%s: ", prompt_start);
115
} else {
116
ret = asprintf(&prompt, "%s (%s): ", prompt_start,
117
crypttarget);
118
}
119
} else {
120
if(crypttarget == NULL){
121
ret = asprintf(&prompt, "%s %s: ", prompt_start, cryptsource);
122
} else {
123
ret = asprintf(&prompt, "%s %s (%s): ", prompt_start,
124
cryptsource, crypttarget);
125
}
126
}
127
if(ret == -1){
128
return EXIT_FAILURE;
129
}
338
char *prompt = makeprompt();
339
if(prompt == NULL){
340
status = EX_OSERR;
341
goto failure;
130
342
}
131
343
132
344
/* Find usplash process */
133
pid_t usplash_pid = 0;
134
345
char *cmdline = NULL;
135
346
size_t cmdline_len = 0;
136
const char usplash_name[] = "/sbin/usplash";
137
{
138
DIR *proc_dir = opendir("/proc");
139
if(proc_dir == NULL){
140
free(prompt);
141
perror("opendir");
142
return EXIT_FAILURE;
143
}
144
for(struct dirent *proc_ent = readdir(proc_dir);
145
proc_ent != NULL;
146
proc_ent = readdir(proc_dir)){
147
pid_t pid = (pid_t) strtoul(proc_ent->d_name, NULL, 10);
148
if(pid == 0){
149
/* Not a process */
150
continue;
151
}
152
/* Find the executable name by doing readlink() on the
153
/proc/<pid>/exe link */
154
char exe_target[sizeof(usplash_name)];
155
{
156
/* create file name string */
157
char *exe_link;
158
ret = asprintf(&exe_link, "/proc/%s/exe", proc_ent->d_name);
159
if(ret == -1){
160
perror("asprintf");
161
free(prompt);
162
closedir(proc_dir);
163
return EXIT_FAILURE;
164
}
165
166
/* Check that it refers to a symlink owned by root:root */
167
struct stat exe_stat;
168
ret = lstat(exe_link, &exe_stat);
169
if(ret == -1){
170
perror("lstat");
171
free(exe_link);
172
free(prompt);
173
closedir(proc_dir);
174
return EXIT_FAILURE;
175
}
176
if(not S_ISLNK(exe_stat.st_mode)
177
or exe_stat.st_uid != 0
178
or exe_stat.st_gid != 0){
179
free(exe_link);
180
continue;
181
}
182
183
sret = readlink(exe_link, exe_target, sizeof(exe_target));
184
free(exe_link);
185
if(sret == -1){
186
continue;
187
}
188
}
189
if((sret == ((ssize_t)sizeof(exe_target)-1))
190
and (memcmp(usplash_name, exe_target,
191
sizeof(exe_target)-1) == 0)){
192
usplash_pid = pid;
193
/* Read and save the command line of usplash in "cmdline" */
194
{
195
/* Open /proc/<pid>/cmdline */
196
int cl_fd;
197
{
198
char *cmdline_filename;
199
ret = asprintf(&cmdline_filename, "/proc/%s/cmdline",
200
proc_ent->d_name);
201
if(ret == -1){
202
perror("asprintf");
203
free(prompt);
204
closedir(proc_dir);
205
return EXIT_FAILURE;
206
}
207
cl_fd = open(cmdline_filename, O_RDONLY);
208
if(cl_fd == -1){
209
perror("open");
210
free(cmdline_filename);
211
free(prompt);
212
closedir(proc_dir);
213
return EXIT_FAILURE;
214
}
215
free(cmdline_filename);
216
}
217
size_t cmdline_allocated = 0;
218
char *tmp;
219
const size_t blocksize = 1024;
220
do{
221
if(cmdline_len + blocksize > cmdline_allocated){
222
tmp = realloc(cmdline, cmdline_allocated + blocksize);
223
if(tmp == NULL){
224
perror("realloc");
225
free(cmdline);
226
free(prompt);
227
closedir(proc_dir);
228
return EXIT_FAILURE;
229
}
230
cmdline = tmp;
231
cmdline_allocated += blocksize;
232
}
233
sret = read(cl_fd, cmdline + cmdline_len,
234
cmdline_allocated - cmdline_len);
235
if(sret == -1){
236
perror("read");
237
free(cmdline);
238
free(prompt);
239
closedir(proc_dir);
240
return EXIT_FAILURE;
241
}
242
cmdline_len += (size_t)sret;
243
} while(sret != 0);
244
close(cl_fd);
245
}
246
break;
247
}
248
}
249
closedir(proc_dir);
250
}
347
usplash_pid = find_usplash(&cmdline, &cmdline_len);
251
348
if(usplash_pid == 0){
252
free(prompt);
253
return EXIT_FAILURE;
349
status = EX_UNAVAILABLE;
350
goto failure;
254
351
}
255
352
256
353
/* Set up the signal handler */
259
356
new_action = { .sa_handler = termination_handler,
260
357
.sa_flags = 0 };
261
358
sigemptyset(&new_action.sa_mask);
262
sigaddset(&new_action.sa_mask, SIGINT);
263
sigaddset(&new_action.sa_mask, SIGHUP);
264
sigaddset(&new_action.sa_mask, SIGTERM);
359
ret = sigaddset(&new_action.sa_mask, SIGINT);
360
if(ret == -1){
361
error_plus(0, errno, "sigaddset");
362
status = EX_OSERR;
363
goto failure;
364
}
365
ret = sigaddset(&new_action.sa_mask, SIGHUP);
366
if(ret == -1){
367
error_plus(0, errno, "sigaddset");
368
status = EX_OSERR;
369
goto failure;
370
}
371
ret = sigaddset(&new_action.sa_mask, SIGTERM);
372
if(ret == -1){
373
error_plus(0, errno, "sigaddset");
374
status = EX_OSERR;
375
goto failure;
376
}
265
377
ret = sigaction(SIGINT, NULL, &old_action);
266
378
if(ret == -1){
267
perror("sigaction");
268
free(prompt);
269
return EXIT_FAILURE;
379
if(errno != EINTR){
380
error_plus(0, errno, "sigaction");
381
status = EX_OSERR;
382
}
383
goto failure;
270
384
}
271
385
if(old_action.sa_handler != SIG_IGN){
272
386
ret = sigaction(SIGINT, &new_action, NULL);
273
387
if(ret == -1){
274
perror("sigaction");
275
free(prompt);
276
return EXIT_FAILURE;
388
if(errno != EINTR){
389
error_plus(0, errno, "sigaction");
390
status = EX_OSERR;
391
}
392
goto failure;
277
393
}
278
394
}
279
395
ret = sigaction(SIGHUP, NULL, &old_action);
280
396
if(ret == -1){
281
perror("sigaction");
282
free(prompt);
283
return EXIT_FAILURE;
397
if(errno != EINTR){
398
error_plus(0, errno, "sigaction");
399
status = EX_OSERR;
400
}
401
goto failure;
284
402
}
285
403
if(old_action.sa_handler != SIG_IGN){
286
404
ret = sigaction(SIGHUP, &new_action, NULL);
287
405
if(ret == -1){
288
perror("sigaction");
289
free(prompt);
290
return EXIT_FAILURE;
406
if(errno != EINTR){
407
error_plus(0, errno, "sigaction");
408
status = EX_OSERR;
409
}
410
goto failure;
291
411
}
292
412
}
293
413
ret = sigaction(SIGTERM, NULL, &old_action);
294
414
if(ret == -1){
295
perror("sigaction");
296
free(prompt);
297
return EXIT_FAILURE;
415
if(errno != EINTR){
416
error_plus(0, errno, "sigaction");
417
status = EX_OSERR;
418
}
419
goto failure;
298
420
}
299
421
if(old_action.sa_handler != SIG_IGN){
300
422
ret = sigaction(SIGTERM, &new_action, NULL);
301
423
if(ret == -1){
302
perror("sigaction");
303
free(prompt);
304
return EXIT_FAILURE;
424
if(errno != EINTR){
425
error_plus(0, errno, "sigaction");
426
status = EX_OSERR;
427
}
428
goto failure;
305
429
}
306
430
}
307
431
}
308
432
433
usplash_accessed = true;
309
434
/* Write command to FIFO */
310
if(not interrupted_by_signal){
311
if(not usplash_write("TIMEOUT", "0")
312
and (errno != EINTR)){
313
perror("usplash_write");
314
an_error_occured = true;
315
}
316
}
317
if(not interrupted_by_signal and not an_error_occured){
318
if(not usplash_write("INPUTQUIET", prompt)
319
and (errno != EINTR)){
320
perror("usplash_write");
321
an_error_occured = true;
322
}
323
}
435
if(not usplash_write(&fifo_fd, "TIMEOUT", "0")){
436
if(errno != EINTR){
437
error_plus(0, errno, "usplash_write");
438
status = EX_OSERR;
439
}
440
goto failure;
441
}
442
443
if(interrupted_by_signal){
444
goto failure;
445
}
446
447
if(not usplash_write(&fifo_fd, "INPUTQUIET", prompt)){
448
if(errno != EINTR){
449
error_plus(0, errno, "usplash_write");
450
status = EX_OSERR;
451
}
452
goto failure;
453
}
454
455
if(interrupted_by_signal){
456
goto failure;
457
}
458
324
459
free(prompt);
325
326
/* This is not really a loop; while() is used to be able to "break"
327
out of it; those breaks are marked "Big" */
328
while(not interrupted_by_signal and not an_error_occured){
329
char *buf = NULL;
330
size_t buf_len = 0;
331
332
/* Open FIFO */
333
int fifo_fd;
334
do{
335
fifo_fd = open("/dev/.initramfs/usplash_outfifo", O_RDONLY);
336
if(fifo_fd == -1){
337
if(errno != EINTR){
338
perror("open");
339
an_error_occured = true;
340
break;
341
}
342
if(interrupted_by_signal){
343
break;
344
}
345
}
346
}while(fifo_fd == -1);
347
if(interrupted_by_signal or an_error_occured){
348
break; /* Big */
349
}
350
351
/* Read from FIFO */
352
size_t buf_allocated = 0;
353
const size_t blocksize = 1024;
354
do{
355
if(buf_len + blocksize > buf_allocated){
356
char *tmp = realloc(buf, buf_allocated + blocksize);
357
if(tmp == NULL){
358
perror("realloc");
359
an_error_occured = true;
360
break;
361
}
362
buf = tmp;
363
buf_allocated += blocksize;
364
}
365
do{
366
sret = read(fifo_fd, buf + buf_len, buf_allocated - buf_len);
367
if(sret == -1){
368
if(errno != EINTR){
369
perror("read");
370
an_error_occured = true;
371
break;
372
}
373
if(interrupted_by_signal){
374
break;
375
}
376
}
377
}while(sret == -1);
378
if(interrupted_by_signal or an_error_occured){
379
break;
380
}
381
382
buf_len += (size_t)sret;
383
}while(sret != 0);
384
close(fifo_fd);
385
if(interrupted_by_signal or an_error_occured){
386
break; /* Big */
387
}
388
389
if(not usplash_write("TIMEOUT", "15")
390
and (errno != EINTR)){
391
perror("usplash_write");
392
an_error_occured = true;
393
}
394
if(interrupted_by_signal or an_error_occured){
395
break; /* Big */
396
}
397
398
/* Print password to stdout */
399
size_t written = 0;
400
while(written < buf_len){
401
do{
402
sret = write(STDOUT_FILENO, buf + written, buf_len - written);
403
if(sret == -1){
404
if(errno != EINTR){
405
perror("write");
406
an_error_occured = true;
407
break;
408
}
409
if(interrupted_by_signal){
410
break;
411
}
412
}
413
}while(sret == -1);
414
if(interrupted_by_signal or an_error_occured){
415
break;
416
}
417
written += (size_t)sret;
418
}
419
free(buf);
420
if(not interrupted_by_signal and not an_error_occured){
421
free(cmdline);
422
return EXIT_SUCCESS;
423
}
424
break; /* Big */
425
} /* end of non-loop while() */
426
427
/* If we got here, an error or interrupt must have happened */
428
429
/* Create argc and argv for new usplash*/
430
int cmdline_argc = 0;
431
char **cmdline_argv = malloc(sizeof(char *));
432
{
433
size_t position = 0;
434
while(position < cmdline_len){
435
char **tmp = realloc(cmdline_argv,
436
(sizeof(char *)
437
* (size_t)(cmdline_argc + 2)));
460
prompt = NULL;
461
462
/* Read reply from usplash */
463
/* Open FIFO */
464
outfifo_fd = open("/dev/.initramfs/usplash_outfifo", O_RDONLY);
465
if(outfifo_fd == -1){
466
if(errno != EINTR){
467
error_plus(0, errno, "open");
468
status = EX_OSERR;
469
}
470
goto failure;
471
}
472
473
if(interrupted_by_signal){
474
goto failure;
475
}
476
477
/* Read from FIFO */
478
size_t buf_allocated = 0;
479
const size_t blocksize = 1024;
480
do {
481
/* Allocate more space */
482
if(buf_len + blocksize > buf_allocated){
483
char *tmp = realloc(buf, buf_allocated + blocksize);
438
484
if(tmp == NULL){
439
perror("realloc");
440
free(cmdline_argv);
441
return EXIT_FAILURE;
442
}
443
cmdline_argv = tmp;
444
cmdline_argv[cmdline_argc] = cmdline + position;
445
cmdline_argc++;
446
position += strlen(cmdline + position) + 1;
447
}
448
cmdline_argv[cmdline_argc] = NULL;
449
}
485
if(errno != EINTR){
486
error_plus(0, errno, "realloc");
487
status = EX_OSERR;
488
}
489
goto failure;
490
}
491
buf = tmp;
492
buf_allocated += blocksize;
493
}
494
sret = read(outfifo_fd, buf + buf_len,
495
buf_allocated - buf_len);
496
if(sret == -1){
497
if(errno != EINTR){
498
error_plus(0, errno, "read");
499
status = EX_OSERR;
500
}
501
close(outfifo_fd);
502
goto failure;
503
}
504
if(interrupted_by_signal){
505
break;
506
}
507
508
buf_len += (size_t)sret;
509
} while(sret != 0);
510
ret = close(outfifo_fd);
511
if(ret == -1){
512
if(errno != EINTR){
513
error_plus(0, errno, "close");
514
status = EX_OSERR;
515
}
516
goto failure;
517
}
518
outfifo_fd = -1;
519
520
if(interrupted_by_signal){
521
goto failure;
522
}
523
524
if(not usplash_write(&fifo_fd, "TIMEOUT", "15")){
525
if(errno != EINTR){
526
error_plus(0, errno, "usplash_write");
527
status = EX_OSERR;
528
}
529
goto failure;
530
}
531
532
if(interrupted_by_signal){
533
goto failure;
534
}
535
536
ret = close(fifo_fd);
537
if(ret == -1){
538
if(errno != EINTR){
539
error_plus(0, errno, "close");
540
status = EX_OSERR;
541
}
542
goto failure;
543
}
544
fifo_fd = -1;
545
546
/* Print password to stdout */
547
size_t written = 0;
548
while(written < buf_len){
549
do {
550
sret = write(STDOUT_FILENO, buf + written, buf_len - written);
551
if(sret == -1){
552
if(errno != EINTR){
553
error_plus(0, errno, "write");
554
status = EX_OSERR;
555
}
556
goto failure;
557
}
558
} while(sret == -1);
559
560
if(interrupted_by_signal){
561
goto failure;
562
}
563
written += (size_t)sret;
564
}
565
free(buf);
566
buf = NULL;
567
568
if(interrupted_by_signal){
569
goto failure;
570
}
571
572
free(cmdline);
573
return EXIT_SUCCESS;
574
575
failure:
576
577
free(buf);
578
579
free(prompt);
580
581
/* If usplash was never accessed, we can stop now */
582
if(not usplash_accessed){
583
return status;
584
}
585
586
/* Close FIFO */
587
if(fifo_fd != -1){
588
ret = close(fifo_fd);
589
if(ret == -1 and errno != EINTR){
590
error_plus(0, errno, "close");
591
}
592
fifo_fd = -1;
593
}
594
595
/* Close output FIFO */
596
if(outfifo_fd != -1){
597
ret = close(outfifo_fd);
598
if(ret == -1){
599
error_plus(0, errno, "close");
600
}
601
}
602
603
/* Create argv for new usplash*/
604
char **cmdline_argv = malloc((argz_count(cmdline, cmdline_len) + 1)
605
* sizeof(char *)); /* Count args */
606
if(cmdline_argv == NULL){
607
error_plus(0, errno, "malloc");
608
return status;
609
}
610
argz_extract(cmdline, cmdline_len, cmdline_argv); /* Create argv */
611
450
612
/* Kill old usplash */
451
613
kill(usplash_pid, SIGTERM);
452
614
sleep(2);
454
616
kill(usplash_pid, SIGKILL);
455
617
sleep(1);
456
618
}
619
457
620
pid_t new_usplash_pid = fork();
458
621
if(new_usplash_pid == 0){
459
622
/* Child; will become new usplash process */
460
623
461
624
/* Make the effective user ID (root) the only user ID instead of
462
the real user ID (mandos) */
625
the real user ID (_mandos) */
463
626
ret = setuid(geteuid());
464
627
if(ret == -1){
465
perror("setuid");
628
error_plus(0, errno, "setuid");
466
629
}
467
630
468
631
setsid();
469
632
ret = chdir("/");
633
if(ret == -1){
634
error_plus(0, errno, "chdir");
635
_exit(EX_OSERR);
636
}
470
637
/* if(fork() != 0){ */
471
638
/* _exit(EXIT_SUCCESS); */
472
639
/* } */
473
640
ret = dup2(STDERR_FILENO, STDOUT_FILENO); /* replace our stdout */
474
641
if(ret == -1){
475
perror("dup2");
476
_exit(EXIT_FAILURE);
642
error_plus(0, errno, "dup2");
643
_exit(EX_OSERR);
477
644
}
478
645
479
646
execv(usplash_name, cmdline_argv);
480
647
if(not interrupted_by_signal){
481
perror("execv");
648
error_plus(0, errno, "execv");
482
649
}
483
650
free(cmdline);
484
651
free(cmdline_argv);
485
_exit(EXIT_FAILURE);
652
_exit(EX_OSERR);
486
653
}
487
654
free(cmdline);
488
655
free(cmdline_argv);
489
656
sleep(2);
490
if(not usplash_write("PULSATE", NULL)
491
and (errno != EINTR)){
492
perror("usplash_write");
493
}
494
495
return EXIT_FAILURE;
657
if(not usplash_write(&fifo_fd, "PULSATE", NULL)){
658
if(errno != EINTR){
659
error_plus(0, errno, "usplash_write");
660
}
661
}
662
663
/* Close FIFO (again) */
664
if(fifo_fd != -1){
665
ret = close(fifo_fd);
666
if(ret == -1 and errno != EINTR){
667
error_plus(0, errno, "close");
668
}
669
fifo_fd = -1;
670
}
671
672
if(interrupted_by_signal){
673
struct sigaction signal_action = { .sa_handler = SIG_DFL };
674
sigemptyset(&signal_action.sa_mask);
675
ret = (int)TEMP_FAILURE_RETRY(sigaction(signal_received,
676
&signal_action, NULL));
677
if(ret == -1){
678
error_plus(0, errno, "sigaction");
679
}
680
do {
681
ret = raise(signal_received);
682
} while(ret != 0 and errno == EINTR);
683
if(ret != 0){
684
error_plus(0, errno, "raise");
685
abort();
686
}
687
TEMP_FAILURE_RETRY(pause());
688
}
689
690
return status;
496
691
}
Loggerhead is a web-based interface for Breezy
Version: 2.0.2.dev0