To get this branch, use:
bzr branch
http://bzr.recompile.se/loggerhead/mandos/release
« back to all changes in this revision
Viewing changes to plugins.d/usplash.c
- browse files at revision 237.7.785
- compare with another revision
- download diff
- download tarball
- view history from revision 237.7.785
- Committer: Teddy Hogeborn
- Date: 2021-02-03 23:10:42 UTC
- mto: This revision was merged to the branch mainline in revision 406.
- 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(),
4
sigaction, SIGINT, SIG_IGN, SIGHUP,
5
SIGTERM, kill(), SIGKILL */
6
#include <stddef.h> /* NULL */
7
#include <stdlib.h> /* getenv() */
8
#include <stdio.h> /* asprintf(), perror() */
9
#include <stdlib.h> /* EXIT_FAILURE, EXIT_SUCCESS,
10
strtoul(), free() */
11
#include <sys/types.h> /* pid_t, DIR, struct dirent,
12
ssize_t */
13
#include <dirent.h> /* opendir(), readdir(), closedir() */
14
#include <unistd.h> /* readlink(), fork(), execl(),
15
_exit */
16
#include <string.h> /* memcmp() */
17
#include <iso646.h> /* and */
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() */
18
41
#include <stdbool.h> /* bool, false, true */
19
#include <errno.h> /* errno */
20
#include <sys/wait.h> /* waitpid(), WIFEXITED(),
21
WEXITSTATUS() */
22
#include <fcntl.h> /* open(), O_RDONLY */
42
#include <fcntl.h> /* open(), O_WRONLY, O_RDONLY */
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() */
23
62
24
63
sig_atomic_t interrupted_by_signal = 0;
25
26
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
}
27
95
interrupted_by_signal = 1;
96
signal_received = signum;
28
97
}
29
98
30
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){
31
101
/*
32
* usplash_write("TIMEOUT", "15"); -> "TIMEOUT 15\0"
33
* usplash_write("PULSATE", NULL); -> "PULSATE\0"
102
* usplash_write(&fd, "TIMEOUT", "15") will write "TIMEOUT 15\0"
103
* usplash_write(&fd, "PULSATE", NULL) will write "PULSATE\0"
34
104
* SEE ALSO
35
105
* usplash_write(8)
36
106
*/
37
107
int ret;
38
int fifo_fd;
39
do{
40
fifo_fd = open("/dev/.initramfs/usplash_fifo", O_WRONLY);
41
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){
42
111
return false;
43
112
}
44
}while(fifo_fd == -1);
113
*fifo_fd_r = ret;
114
}
45
115
46
116
const char *cmd_line;
117
size_t cmd_line_len;
47
118
char *cmd_line_alloc = NULL;
48
119
if(arg == NULL){
49
120
cmd_line = cmd;
50
ret = (int)strlen(cmd);
51
}else{
52
do{
121
cmd_line_len = strlen(cmd) + 1;
122
} else {
123
do {
53
124
ret = asprintf(&cmd_line_alloc, "%s %s", cmd, arg);
54
if(ret == -1 and (errno != EINTR or interrupted_by_signal)){
125
if(ret == -1){
55
126
int e = errno;
56
close(fifo_fd);
127
close(*fifo_fd_r);
57
128
errno = e;
58
129
return false;
59
130
}
60
}while(ret == -1);
131
} while(ret == -1);
61
132
cmd_line = cmd_line_alloc;
133
cmd_line_len = (size_t)ret + 1;
62
134
}
63
135
64
size_t cmd_line_len = (size_t)ret + 1;
65
136
size_t written = 0;
66
while(not interrupted_by_signal and written < cmd_line_len){
67
ret = write(fifo_fd, cmd_line + written,
68
cmd_line_len - written);
69
if(ret == -1){
70
if(errno != EINTR or interrupted_by_signal){
71
int e = errno;
72
close(fifo_fd);
73
free(cmd_line_alloc);
74
errno = e;
75
return false;
76
} else {
77
continue;
78
}
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;
79
147
}
80
written += (size_t)ret;
148
written += (size_t)sret;
81
149
}
82
150
free(cmd_line_alloc);
83
do{
84
ret = close(fifo_fd);
85
if(ret == -1 and (errno != EINTR or interrupted_by_signal)){
86
return false;
87
}
88
}while(ret == -1);
89
if(interrupted_by_signal){
90
return false;
91
}
151
92
152
return true;
93
153
}
94
154
95
int main(__attribute__((unused))int argc,
96
__attribute__((unused))char **argv){
97
int ret = 0;
98
ssize_t sret;
99
bool an_error_occured = false;
100
101
/* Create prompt string */
102
char *prompt = NULL;
103
{
104
const char *const cryptsource = getenv("cryptsource");
105
const char *const crypttarget = getenv("crypttarget");
106
const char *const prompt_start = "Enter passphrase to unlock the disk";
107
108
if(cryptsource == NULL){
109
if(crypttarget == NULL){
110
ret = asprintf(&prompt, "%s: ", prompt_start);
111
} else {
112
ret = asprintf(&prompt, "%s (%s): ", prompt_start,
113
crypttarget);
114
}
115
} else {
116
if(crypttarget == NULL){
117
ret = asprintf(&prompt, "%s %s: ", prompt_start, cryptsource);
118
} else {
119
ret = asprintf(&prompt, "%s %s (%s): ", prompt_start,
120
cryptsource, crypttarget);
121
}
122
}
123
if(ret == -1){
124
return EXIT_FAILURE;
125
}
126
}
127
128
/* Find usplash process */
129
pid_t usplash_pid = 0;
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;
130
187
char *cmdline = NULL;
131
188
size_t cmdline_len = 0;
132
const char usplash_name[] = "/sbin/usplash";
133
{
134
DIR *proc_dir = opendir("/proc");
135
if(proc_dir == NULL){
136
free(prompt);
137
perror("opendir");
138
return EXIT_FAILURE;
139
}
140
for(struct dirent *proc_ent = readdir(proc_dir);
141
proc_ent != NULL;
142
proc_ent = readdir(proc_dir)){
143
pid_t pid = (pid_t) strtoul(proc_ent->d_name, NULL, 10);
144
if(pid == 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){
145
205
/* Not a process */
146
continue;
147
}
148
/* Find the executable name by doing readlink() on the
149
/proc/<pid>/exe link */
150
char exe_target[sizeof(usplash_name)];
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;
151
257
{
152
char *exe_link;
153
ret = asprintf(&exe_link, "/proc/%s/exe", proc_ent->d_name);
258
char *cmdline_filename;
259
ret = asprintf(&cmdline_filename, "/proc/%s/cmdline",
260
proc_ent->d_name);
154
261
if(ret == -1){
155
perror("asprintf");
156
free(prompt);
157
closedir(proc_dir);
158
return EXIT_FAILURE;
159
}
160
sret = readlink(exe_link, exe_target, sizeof(exe_target));
161
free(exe_link);
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
}
162
271
}
163
if((sret == ((ssize_t)sizeof(exe_target)-1))
164
and (memcmp(usplash_name, exe_target,
165
sizeof(exe_target)-1) == 0)){
166
usplash_pid = pid;
167
/* Read and save the command line of usplash in "cmdline" */
168
{
169
/* Open /proc/<pid>/cmdline */
170
int cl_fd;
171
{
172
char *cmdline_filename;
173
ret = asprintf(&cmdline_filename, "/proc/%s/cmdline",
174
proc_ent->d_name);
175
if(ret == -1){
176
perror("asprintf");
177
free(prompt);
178
closedir(proc_dir);
179
return EXIT_FAILURE;
180
}
181
cl_fd = open(cmdline_filename, O_RDONLY);
182
if(cl_fd == -1){
183
perror("open");
184
free(cmdline_filename);
185
free(prompt);
186
closedir(proc_dir);
187
return EXIT_FAILURE;
188
}
189
free(cmdline_filename);
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;
190
283
}
191
size_t cmdline_allocated = 0;
192
char *tmp;
193
const size_t blocksize = 1024;
194
do{
195
if(cmdline_len + blocksize > cmdline_allocated){
196
tmp = realloc(cmdline, cmdline_allocated + blocksize);
197
if(tmp == NULL){
198
perror("realloc");
199
free(cmdline);
200
free(prompt);
201
closedir(proc_dir);
202
return EXIT_FAILURE;
203
}
204
cmdline = tmp;
205
cmdline_allocated += blocksize;
206
}
207
sret = read(cl_fd, cmdline + cmdline_len,
208
cmdline_allocated - cmdline_len);
209
if(sret == -1){
210
perror("read");
211
free(cmdline);
212
free(prompt);
213
closedir(proc_dir);
214
return EXIT_FAILURE;
215
}
216
cmdline_len += (size_t)sret;
217
} while(sret != 0);
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");
218
292
close(cl_fd);
293
goto fail_find_usplash;
219
294
}
220
break;
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;
221
301
}
222
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;
223
320
closedir(proc_dir);
224
}
321
errno = e;
322
}
323
return 0;
324
}
325
326
int main(__attribute__((unused))int argc,
327
__attribute__((unused))char **argv){
328
int ret = 0;
329
ssize_t sret;
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 */
337
338
char *prompt = makeprompt();
339
if(prompt == NULL){
340
status = EX_OSERR;
341
goto failure;
342
}
343
344
/* Find usplash process */
345
char *cmdline = NULL;
346
size_t cmdline_len = 0;
347
usplash_pid = find_usplash(&cmdline, &cmdline_len);
225
348
if(usplash_pid == 0){
226
free(prompt);
227
return EXIT_FAILURE;
349
status = EX_UNAVAILABLE;
350
goto failure;
228
351
}
229
352
230
353
/* Set up the signal handler */
233
356
new_action = { .sa_handler = termination_handler,
234
357
.sa_flags = 0 };
235
358
sigemptyset(&new_action.sa_mask);
236
sigaddset(&new_action.sa_mask, SIGINT);
237
sigaddset(&new_action.sa_mask, SIGHUP);
238
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
}
239
377
ret = sigaction(SIGINT, NULL, &old_action);
240
378
if(ret == -1){
241
perror("sigaction");
242
free(prompt);
243
return EXIT_FAILURE;
379
if(errno != EINTR){
380
error_plus(0, errno, "sigaction");
381
status = EX_OSERR;
382
}
383
goto failure;
244
384
}
245
if (old_action.sa_handler != SIG_IGN){
385
if(old_action.sa_handler != SIG_IGN){
246
386
ret = sigaction(SIGINT, &new_action, NULL);
247
387
if(ret == -1){
248
perror("sigaction");
249
free(prompt);
250
return EXIT_FAILURE;
388
if(errno != EINTR){
389
error_plus(0, errno, "sigaction");
390
status = EX_OSERR;
391
}
392
goto failure;
251
393
}
252
394
}
253
395
ret = sigaction(SIGHUP, NULL, &old_action);
254
396
if(ret == -1){
255
perror("sigaction");
256
free(prompt);
257
return EXIT_FAILURE;
397
if(errno != EINTR){
398
error_plus(0, errno, "sigaction");
399
status = EX_OSERR;
400
}
401
goto failure;
258
402
}
259
if (old_action.sa_handler != SIG_IGN){
403
if(old_action.sa_handler != SIG_IGN){
260
404
ret = sigaction(SIGHUP, &new_action, NULL);
261
405
if(ret == -1){
262
perror("sigaction");
263
free(prompt);
264
return EXIT_FAILURE;
406
if(errno != EINTR){
407
error_plus(0, errno, "sigaction");
408
status = EX_OSERR;
409
}
410
goto failure;
265
411
}
266
412
}
267
413
ret = sigaction(SIGTERM, NULL, &old_action);
268
414
if(ret == -1){
269
perror("sigaction");
270
free(prompt);
271
return EXIT_FAILURE;
415
if(errno != EINTR){
416
error_plus(0, errno, "sigaction");
417
status = EX_OSERR;
418
}
419
goto failure;
272
420
}
273
if (old_action.sa_handler != SIG_IGN){
421
if(old_action.sa_handler != SIG_IGN){
274
422
ret = sigaction(SIGTERM, &new_action, NULL);
275
423
if(ret == -1){
276
perror("sigaction");
277
free(prompt);
278
return EXIT_FAILURE;
424
if(errno != EINTR){
425
error_plus(0, errno, "sigaction");
426
status = EX_OSERR;
427
}
428
goto failure;
279
429
}
280
430
}
281
431
}
282
432
433
usplash_accessed = true;
283
434
/* Write command to FIFO */
284
if(not interrupted_by_signal){
285
if(not usplash_write("TIMEOUT", "0")
286
and (errno != EINTR)){
287
perror("usplash_write");
288
an_error_occured = true;
289
}
290
}
291
if(not interrupted_by_signal and not an_error_occured){
292
if(not usplash_write("INPUTQUIET", prompt)
293
and (errno != EINTR)){
294
perror("usplash_write");
295
an_error_occured = true;
296
}
297
}
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
298
459
free(prompt);
299
300
/* This is not really a loop; while() is used to be able to "break"
301
out of it; those breaks are marked "Big" */
302
while(not interrupted_by_signal and not an_error_occured){
303
char *buf = NULL;
304
size_t buf_len = 0;
305
306
/* Open FIFO */
307
int fifo_fd;
308
do{
309
fifo_fd = open("/dev/.initramfs/usplash_outfifo", O_RDONLY);
310
if(fifo_fd == -1){
311
if(errno != EINTR){
312
perror("open");
313
an_error_occured = true;
314
break;
315
}
316
if(interrupted_by_signal){
317
break;
318
}
319
}
320
}while(fifo_fd == -1);
321
if(interrupted_by_signal or an_error_occured){
322
break; /* Big */
323
}
324
325
/* Read from FIFO */
326
size_t buf_allocated = 0;
327
const size_t blocksize = 1024;
328
do{
329
if(buf_len + blocksize > buf_allocated){
330
char *tmp = realloc(buf, buf_allocated + blocksize);
331
if(tmp == NULL){
332
perror("realloc");
333
an_error_occured = true;
334
break;
335
}
336
buf = tmp;
337
buf_allocated += blocksize;
338
}
339
do{
340
sret = read(fifo_fd, buf + buf_len, buf_allocated - buf_len);
341
if(sret == -1){
342
if(errno != EINTR){
343
perror("read");
344
an_error_occured = true;
345
break;
346
}
347
if(interrupted_by_signal){
348
break;
349
}
350
}
351
}while(sret == -1);
352
if(interrupted_by_signal or an_error_occured){
353
break;
354
}
355
356
buf_len += (size_t)sret;
357
}while(sret != 0);
358
close(fifo_fd);
359
if(interrupted_by_signal or an_error_occured){
360
break; /* Big */
361
}
362
363
if(not usplash_write("TIMEOUT", "15")
364
and (errno != EINTR)){
365
perror("usplash_write");
366
an_error_occured = true;
367
}
368
if(interrupted_by_signal or an_error_occured){
369
break; /* Big */
370
}
371
372
/* Print password to stdout */
373
size_t written = 0;
374
do{
375
do{
376
sret = write(STDOUT_FILENO, buf + written, buf_len - written);
377
if(sret == -1){
378
if(errno != EINTR){
379
perror("write");
380
an_error_occured = true;
381
break;
382
}
383
if(interrupted_by_signal){
384
break;
385
}
386
}
387
}while(sret == -1);
388
if(interrupted_by_signal or an_error_occured){
389
break;
390
}
391
392
written += (size_t)sret;
393
}while(written < buf_len);
394
if(not interrupted_by_signal and not an_error_occured){
395
return EXIT_SUCCESS;
396
}
397
break; /* Big */
398
}
399
400
/* If we got here, an error or interrupt must have happened */
401
402
int cmdline_argc = 0;
403
char **cmdline_argv = malloc(sizeof(char *));
404
/* Create argv and argc for new usplash*/
405
{
406
size_t position = 0;
407
while(position < cmdline_len){
408
char **tmp = realloc(cmdline_argv,
409
(sizeof(char *) * (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);
410
484
if(tmp == NULL){
411
perror("realloc");
412
free(cmdline_argv);
413
return EXIT_FAILURE;
414
}
415
cmdline_argv = tmp;
416
cmdline_argv[cmdline_argc] = cmdline + position;
417
cmdline_argc++;
418
position += strlen(cmdline + position) + 1;
419
}
420
cmdline_argv[cmdline_argc] = NULL;
421
}
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
422
612
/* Kill old usplash */
423
kill(usplash_pid, SIGTERM);
424
sleep(2);
613
kill(usplash_pid, SIGTERM);
614
sleep(2);
425
615
while(kill(usplash_pid, 0) == 0){
426
616
kill(usplash_pid, SIGKILL);
427
617
sleep(1);
428
618
}
619
429
620
pid_t new_usplash_pid = fork();
430
621
if(new_usplash_pid == 0){
431
622
/* Child; will become new usplash process */
432
623
433
624
/* Make the effective user ID (root) the only user ID instead of
434
the real user ID (mandos) */
625
the real user ID (_mandos) */
435
626
ret = setuid(geteuid());
436
if (ret == -1){
437
perror("setuid");
627
if(ret == -1){
628
error_plus(0, errno, "setuid");
438
629
}
439
630
440
631
setsid();
441
632
ret = chdir("/");
633
if(ret == -1){
634
error_plus(0, errno, "chdir");
635
_exit(EX_OSERR);
636
}
442
637
/* if(fork() != 0){ */
443
638
/* _exit(EXIT_SUCCESS); */
444
639
/* } */
445
640
ret = dup2(STDERR_FILENO, STDOUT_FILENO); /* replace our stdout */
446
641
if(ret == -1){
447
perror("dup2");
448
_exit(EXIT_FAILURE);
642
error_plus(0, errno, "dup2");
643
_exit(EX_OSERR);
449
644
}
450
645
451
646
execv(usplash_name, cmdline_argv);
647
if(not interrupted_by_signal){
648
error_plus(0, errno, "execv");
649
}
650
free(cmdline);
651
free(cmdline_argv);
652
_exit(EX_OSERR);
452
653
}
654
free(cmdline);
655
free(cmdline_argv);
453
656
sleep(2);
454
if(not usplash_write("PULSATE", NULL)
455
and (errno != EINTR)){
456
perror("usplash_write");
457
}
458
459
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;
460
691
}
Loggerhead is a web-based interface for Breezy
Version: 2.0.2.dev0