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:
- initramfs-tools-hook-conf
- files modified:
- .bzrignore
added
removed
plugins.d/usplash.c
2
2
/*
3
3
* Usplash - Read a password from usplash and output it
4
4
*
5
* Copyright © 2008,2009 Teddy Hogeborn
6
* Copyright © 2008,2009 Björn Påhlsson
7
*
8
* This program is free software: you can redistribute it and/or
9
* modify it under the terms of the GNU General Public License as
10
* published by the Free Software Foundation, either version 3 of the
11
* License, or (at your option) any later version.
12
*
13
* This program is distributed in the hope that it will be useful, but
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
14
16
* WITHOUT ANY WARRANTY; without even the implied warranty of
15
17
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
16
18
* General Public License for more details.
17
19
*
18
20
* You should have received a copy of the GNU General Public License
19
* along with this program. If not, see
20
* <http://www.gnu.org/licenses/>.
21
* along with Mandos. If not, see <http://www.gnu.org/licenses/>.
21
22
*
22
* Contact the authors at <https://www.fukt.bsnet.se/~belorn/> and
23
* <https://www.fukt.bsnet.se/~teddy/>.
23
* Contact the authors at <mandos@recompile.se>.
24
24
*/
25
25
26
#define _GNU_SOURCE /* asprintf() */
27
#include <signal.h> /* sig_atomic_t, struct sigaction,
28
sigemptyset(), sigaddset(), SIGINT,
29
SIGHUP, SIGTERM, sigaction(),
30
SIG_IGN, kill(), SIGKILL */
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() */
31
41
#include <stdbool.h> /* bool, false, true */
32
42
#include <fcntl.h> /* open(), O_WRONLY, O_RDONLY */
33
#include <iso646.h> /* and, or, not*/
34
#include <errno.h> /* errno, EINTR */
35
#include <sys/types.h> /* size_t, ssize_t, pid_t, DIR, struct
36
dirent */
37
#include <stddef.h> /* NULL */
38
#include <string.h> /* strlen(), memcmp() */
39
#include <stdio.h> /* asprintf(), perror() */
40
#include <unistd.h> /* close(), write(), readlink(),
41
read(), STDOUT_FILENO, sleep(),
42
fork(), setuid(), geteuid(),
43
setsid(), chdir(), dup2(),
44
STDERR_FILENO, execv() */
45
#include <stdlib.h> /* free(), EXIT_FAILURE, strtoul(),
46
realloc(), EXIT_SUCCESS, malloc(),
47
_exit() */
48
#include <stdlib.h> /* getenv() */
49
#include <dirent.h> /* opendir(), readdir(), closedir() */
50
#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() */
51
62
52
63
sig_atomic_t interrupted_by_signal = 0;
53
54
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
}
55
95
interrupted_by_signal = 1;
96
signal_received = signum;
56
97
}
57
98
58
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){
59
101
/*
60
* usplash_write("TIMEOUT", "15") will write "TIMEOUT 15\0"
61
* 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"
62
104
* SEE ALSO
63
105
* usplash_write(8)
64
106
*/
65
107
int ret;
66
int fifo_fd;
67
do{
68
fifo_fd = open("/dev/.initramfs/usplash_fifo", O_WRONLY);
69
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){
70
111
return false;
71
112
}
72
}while(fifo_fd == -1);
113
*fifo_fd_r = ret;
114
}
73
115
74
116
const char *cmd_line;
75
117
size_t cmd_line_len;
76
118
char *cmd_line_alloc = NULL;
77
119
if(arg == NULL){
78
120
cmd_line = cmd;
79
cmd_line_len = strlen(cmd);
80
}else{
81
do{
121
cmd_line_len = strlen(cmd) + 1;
122
} else {
123
do {
82
124
ret = asprintf(&cmd_line_alloc, "%s %s", cmd, arg);
83
if(ret == -1 and (errno != EINTR or interrupted_by_signal)){
125
if(ret == -1){
84
126
int e = errno;
85
close(fifo_fd);
127
close(*fifo_fd_r);
86
128
errno = e;
87
129
return false;
88
130
}
89
}while(ret == -1);
131
} while(ret == -1);
90
132
cmd_line = cmd_line_alloc;
91
133
cmd_line_len = (size_t)ret + 1;
92
134
}
93
135
94
136
size_t written = 0;
95
137
ssize_t sret = 0;
96
while(not interrupted_by_signal and written < cmd_line_len){
97
sret = write(fifo_fd, cmd_line + written,
138
while(written < cmd_line_len){
139
sret = write(*fifo_fd_r, cmd_line + written,
98
140
cmd_line_len - written);
99
141
if(sret == -1){
100
if(errno != EINTR or interrupted_by_signal){
101
int e = errno;
102
close(fifo_fd);
103
free(cmd_line_alloc);
104
errno = e;
105
return false;
106
} else {
107
continue;
108
}
142
int e = errno;
143
close(*fifo_fd_r);
144
free(cmd_line_alloc);
145
errno = e;
146
return false;
109
147
}
110
148
written += (size_t)sret;
111
149
}
112
150
free(cmd_line_alloc);
113
do{
114
ret = close(fifo_fd);
115
if(ret == -1 and (errno != EINTR or interrupted_by_signal)){
116
return false;
117
}
118
}while(ret == -1);
119
if(interrupted_by_signal){
120
return false;
121
}
151
122
152
return true;
123
153
}
124
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
125
326
int main(__attribute__((unused))int argc,
126
327
__attribute__((unused))char **argv){
127
328
int ret = 0;
128
329
ssize_t sret;
129
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 */
130
337
131
/* Create prompt string */
132
char *prompt = NULL;
133
{
134
const char *const cryptsource = getenv("cryptsource");
135
const char *const crypttarget = getenv("crypttarget");
136
const char prompt_start[] = "Enter passphrase to unlock the disk";
137
138
if(cryptsource == NULL){
139
if(crypttarget == NULL){
140
ret = asprintf(&prompt, "%s: ", prompt_start);
141
} else {
142
ret = asprintf(&prompt, "%s (%s): ", prompt_start,
143
crypttarget);
144
}
145
} else {
146
if(crypttarget == NULL){
147
ret = asprintf(&prompt, "%s %s: ", prompt_start, cryptsource);
148
} else {
149
ret = asprintf(&prompt, "%s %s (%s): ", prompt_start,
150
cryptsource, crypttarget);
151
}
152
}
153
if(ret == -1){
154
return EXIT_FAILURE;
155
}
338
char *prompt = makeprompt();
339
if(prompt == NULL){
340
status = EX_OSERR;
341
goto failure;
156
342
}
157
343
158
344
/* Find usplash process */
159
pid_t usplash_pid = 0;
160
345
char *cmdline = NULL;
161
346
size_t cmdline_len = 0;
162
const char usplash_name[] = "/sbin/usplash";
163
{
164
DIR *proc_dir = opendir("/proc");
165
if(proc_dir == NULL){
166
free(prompt);
167
perror("opendir");
168
return EXIT_FAILURE;
169
}
170
for(struct dirent *proc_ent = readdir(proc_dir);
171
proc_ent != NULL;
172
proc_ent = readdir(proc_dir)){
173
pid_t pid = (pid_t) strtoul(proc_ent->d_name, NULL, 10);
174
if(pid == 0){
175
/* Not a process */
176
continue;
177
}
178
/* Find the executable name by doing readlink() on the
179
/proc/<pid>/exe link */
180
char exe_target[sizeof(usplash_name)];
181
{
182
/* create file name string */
183
char *exe_link;
184
ret = asprintf(&exe_link, "/proc/%s/exe", proc_ent->d_name);
185
if(ret == -1){
186
perror("asprintf");
187
free(prompt);
188
closedir(proc_dir);
189
return EXIT_FAILURE;
190
}
191
192
/* Check that it refers to a symlink owned by root:root */
193
struct stat exe_stat;
194
ret = lstat(exe_link, &exe_stat);
195
if(ret == -1){
196
if(errno == ENOENT){
197
free(exe_link);
198
continue;
199
}
200
perror("lstat");
201
free(exe_link);
202
free(prompt);
203
closedir(proc_dir);
204
return EXIT_FAILURE;
205
}
206
if(not S_ISLNK(exe_stat.st_mode)
207
or exe_stat.st_uid != 0
208
or exe_stat.st_gid != 0){
209
free(exe_link);
210
continue;
211
}
212
213
sret = readlink(exe_link, exe_target, sizeof(exe_target));
214
free(exe_link);
215
}
216
if((sret == ((ssize_t)sizeof(exe_target)-1))
217
and (memcmp(usplash_name, exe_target,
218
sizeof(exe_target)-1) == 0)){
219
usplash_pid = pid;
220
/* Read and save the command line of usplash in "cmdline" */
221
{
222
/* Open /proc/<pid>/cmdline */
223
int cl_fd;
224
{
225
char *cmdline_filename;
226
ret = asprintf(&cmdline_filename, "/proc/%s/cmdline",
227
proc_ent->d_name);
228
if(ret == -1){
229
perror("asprintf");
230
free(prompt);
231
closedir(proc_dir);
232
return EXIT_FAILURE;
233
}
234
cl_fd = open(cmdline_filename, O_RDONLY);
235
if(cl_fd == -1){
236
perror("open");
237
free(cmdline_filename);
238
free(prompt);
239
closedir(proc_dir);
240
return EXIT_FAILURE;
241
}
242
free(cmdline_filename);
243
}
244
size_t cmdline_allocated = 0;
245
char *tmp;
246
const size_t blocksize = 1024;
247
do{
248
if(cmdline_len + blocksize > cmdline_allocated){
249
tmp = realloc(cmdline, cmdline_allocated + blocksize);
250
if(tmp == NULL){
251
perror("realloc");
252
free(cmdline);
253
free(prompt);
254
closedir(proc_dir);
255
return EXIT_FAILURE;
256
}
257
cmdline = tmp;
258
cmdline_allocated += blocksize;
259
}
260
sret = read(cl_fd, cmdline + cmdline_len,
261
cmdline_allocated - cmdline_len);
262
if(sret == -1){
263
perror("read");
264
free(cmdline);
265
free(prompt);
266
closedir(proc_dir);
267
return EXIT_FAILURE;
268
}
269
cmdline_len += (size_t)sret;
270
} while(sret != 0);
271
close(cl_fd);
272
}
273
break;
274
}
275
}
276
closedir(proc_dir);
277
}
347
usplash_pid = find_usplash(&cmdline, &cmdline_len);
278
348
if(usplash_pid == 0){
279
free(prompt);
280
return EXIT_FAILURE;
349
status = EX_UNAVAILABLE;
350
goto failure;
281
351
}
282
352
283
353
/* Set up the signal handler */
286
356
new_action = { .sa_handler = termination_handler,
287
357
.sa_flags = 0 };
288
358
sigemptyset(&new_action.sa_mask);
289
sigaddset(&new_action.sa_mask, SIGINT);
290
sigaddset(&new_action.sa_mask, SIGHUP);
291
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
}
292
377
ret = sigaction(SIGINT, NULL, &old_action);
293
378
if(ret == -1){
294
perror("sigaction");
295
free(prompt);
296
return EXIT_FAILURE;
379
if(errno != EINTR){
380
error_plus(0, errno, "sigaction");
381
status = EX_OSERR;
382
}
383
goto failure;
297
384
}
298
385
if(old_action.sa_handler != SIG_IGN){
299
386
ret = sigaction(SIGINT, &new_action, NULL);
300
387
if(ret == -1){
301
perror("sigaction");
302
free(prompt);
303
return EXIT_FAILURE;
388
if(errno != EINTR){
389
error_plus(0, errno, "sigaction");
390
status = EX_OSERR;
391
}
392
goto failure;
304
393
}
305
394
}
306
395
ret = sigaction(SIGHUP, NULL, &old_action);
307
396
if(ret == -1){
308
perror("sigaction");
309
free(prompt);
310
return EXIT_FAILURE;
397
if(errno != EINTR){
398
error_plus(0, errno, "sigaction");
399
status = EX_OSERR;
400
}
401
goto failure;
311
402
}
312
403
if(old_action.sa_handler != SIG_IGN){
313
404
ret = sigaction(SIGHUP, &new_action, NULL);
314
405
if(ret == -1){
315
perror("sigaction");
316
free(prompt);
317
return EXIT_FAILURE;
406
if(errno != EINTR){
407
error_plus(0, errno, "sigaction");
408
status = EX_OSERR;
409
}
410
goto failure;
318
411
}
319
412
}
320
413
ret = sigaction(SIGTERM, NULL, &old_action);
321
414
if(ret == -1){
322
perror("sigaction");
323
free(prompt);
324
return EXIT_FAILURE;
415
if(errno != EINTR){
416
error_plus(0, errno, "sigaction");
417
status = EX_OSERR;
418
}
419
goto failure;
325
420
}
326
421
if(old_action.sa_handler != SIG_IGN){
327
422
ret = sigaction(SIGTERM, &new_action, NULL);
328
423
if(ret == -1){
329
perror("sigaction");
330
free(prompt);
331
return EXIT_FAILURE;
424
if(errno != EINTR){
425
error_plus(0, errno, "sigaction");
426
status = EX_OSERR;
427
}
428
goto failure;
332
429
}
333
430
}
334
431
}
335
432
433
usplash_accessed = true;
336
434
/* Write command to FIFO */
337
if(not interrupted_by_signal){
338
if(not usplash_write("TIMEOUT", "0")
339
and (errno != EINTR)){
340
perror("usplash_write");
341
an_error_occured = true;
342
}
343
}
344
if(not interrupted_by_signal and not an_error_occured){
345
if(not usplash_write("INPUTQUIET", prompt)
346
and (errno != EINTR)){
347
perror("usplash_write");
348
an_error_occured = true;
349
}
350
}
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
351
459
free(prompt);
352
353
/* This is not really a loop; while() is used to be able to "break"
354
out of it; those breaks are marked "Big" */
355
while(not interrupted_by_signal and not an_error_occured){
356
char *buf = NULL;
357
size_t buf_len = 0;
358
359
/* Open FIFO */
360
int fifo_fd;
361
do{
362
fifo_fd = open("/dev/.initramfs/usplash_outfifo", O_RDONLY);
363
if(fifo_fd == -1){
364
if(errno != EINTR){
365
perror("open");
366
an_error_occured = true;
367
break;
368
}
369
if(interrupted_by_signal){
370
break;
371
}
372
}
373
}while(fifo_fd == -1);
374
if(interrupted_by_signal or an_error_occured){
375
break; /* Big */
376
}
377
378
/* Read from FIFO */
379
size_t buf_allocated = 0;
380
const size_t blocksize = 1024;
381
do{
382
if(buf_len + blocksize > buf_allocated){
383
char *tmp = realloc(buf, buf_allocated + blocksize);
384
if(tmp == NULL){
385
perror("realloc");
386
an_error_occured = true;
387
break;
388
}
389
buf = tmp;
390
buf_allocated += blocksize;
391
}
392
do{
393
sret = read(fifo_fd, buf + buf_len, buf_allocated - buf_len);
394
if(sret == -1){
395
if(errno != EINTR){
396
perror("read");
397
an_error_occured = true;
398
break;
399
}
400
if(interrupted_by_signal){
401
break;
402
}
403
}
404
}while(sret == -1);
405
if(interrupted_by_signal or an_error_occured){
406
break;
407
}
408
409
buf_len += (size_t)sret;
410
}while(sret != 0);
411
close(fifo_fd);
412
if(interrupted_by_signal or an_error_occured){
413
break; /* Big */
414
}
415
416
if(not usplash_write("TIMEOUT", "15")
417
and (errno != EINTR)){
418
perror("usplash_write");
419
an_error_occured = true;
420
}
421
if(interrupted_by_signal or an_error_occured){
422
break; /* Big */
423
}
424
425
/* Print password to stdout */
426
size_t written = 0;
427
while(written < buf_len){
428
do{
429
sret = write(STDOUT_FILENO, buf + written, buf_len - written);
430
if(sret == -1){
431
if(errno != EINTR){
432
perror("write");
433
an_error_occured = true;
434
break;
435
}
436
if(interrupted_by_signal){
437
break;
438
}
439
}
440
}while(sret == -1);
441
if(interrupted_by_signal or an_error_occured){
442
break;
443
}
444
written += (size_t)sret;
445
}
446
free(buf);
447
if(not interrupted_by_signal and not an_error_occured){
448
free(cmdline);
449
return EXIT_SUCCESS;
450
}
451
break; /* Big */
452
} /* end of non-loop while() */
453
454
/* If we got here, an error or interrupt must have happened */
455
456
/* Create argc and argv for new usplash*/
457
int cmdline_argc = 0;
458
char **cmdline_argv = malloc(sizeof(char *));
459
{
460
size_t position = 0;
461
while(position < cmdline_len){
462
char **tmp = realloc(cmdline_argv,
463
(sizeof(char *)
464
* (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);
465
484
if(tmp == NULL){
466
perror("realloc");
467
free(cmdline_argv);
468
return EXIT_FAILURE;
469
}
470
cmdline_argv = tmp;
471
cmdline_argv[cmdline_argc] = cmdline + position;
472
cmdline_argc++;
473
position += strlen(cmdline + position) + 1;
474
}
475
cmdline_argv[cmdline_argc] = NULL;
476
}
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
477
612
/* Kill old usplash */
478
613
kill(usplash_pid, SIGTERM);
479
614
sleep(2);
481
616
kill(usplash_pid, SIGKILL);
482
617
sleep(1);
483
618
}
619
484
620
pid_t new_usplash_pid = fork();
485
621
if(new_usplash_pid == 0){
486
622
/* Child; will become new usplash process */
487
623
488
624
/* Make the effective user ID (root) the only user ID instead of
489
the real user ID (mandos) */
625
the real user ID (_mandos) */
490
626
ret = setuid(geteuid());
491
627
if(ret == -1){
492
perror("setuid");
628
error_plus(0, errno, "setuid");
493
629
}
494
630
495
631
setsid();
496
632
ret = chdir("/");
633
if(ret == -1){
634
error_plus(0, errno, "chdir");
635
_exit(EX_OSERR);
636
}
497
637
/* if(fork() != 0){ */
498
638
/* _exit(EXIT_SUCCESS); */
499
639
/* } */
500
640
ret = dup2(STDERR_FILENO, STDOUT_FILENO); /* replace our stdout */
501
641
if(ret == -1){
502
perror("dup2");
503
_exit(EXIT_FAILURE);
642
error_plus(0, errno, "dup2");
643
_exit(EX_OSERR);
504
644
}
505
645
506
646
execv(usplash_name, cmdline_argv);
507
647
if(not interrupted_by_signal){
508
perror("execv");
648
error_plus(0, errno, "execv");
509
649
}
510
650
free(cmdline);
511
651
free(cmdline_argv);
512
_exit(EXIT_FAILURE);
652
_exit(EX_OSERR);
513
653
}
514
654
free(cmdline);
515
655
free(cmdline_argv);
516
656
sleep(2);
517
if(not usplash_write("PULSATE", NULL)
518
and (errno != EINTR)){
519
perror("usplash_write");
520
}
521
522
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;
523
691
}
Loggerhead is a web-based interface for Breezy
Version: 2.0.2.dev0