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/mandos-client.c
- browse files at revision 238
- compare with another revision
- download diff
- download tarball
- view history from revision 238
- Committer: Teddy Hogeborn
- Date: 2008-12-10 01:26:02 UTC
- mfrom: (237.1.2 mandos)
- Revision ID: teddy@fukt.bsnet.se-20081210012602-vhz3h75xkj24t340
First version of a somewhat complete D-Bus server interface. Also
change user/group name to "_mandos".
* debian/mandos.postinst: Rename old "mandos" user and group to
"_mandos"; create "_mandos" user and group
if none exist.
* debian/mandos-client.postinst: - '' -
* initramfs-tools-hook: Try "_mandos" before "mandos" as user and
group name.
* mandos (_datetime_to_dbus_struct): New; was previously local.
(Client.started): Renamed to "last_started". All users changed.
(Client.started): New; boolean.
(Client.dbus_object_path): New.
(Client.check_command): Renamed to "checker_command". All users
changed.
(Client.__init__): Set and use "self.dbus_object_path". Set
"self.started".
(Client.start): Update "self.started". Emit "self.PropertyChanged"
signals for both "started" and "last_started".
(Client.stop): Update "self.started". Emit "self.PropertyChanged"
signal for "started".
(Client.checker_callback): Take additional "command" argument. All
callers changed. Emit
"self.PropertyChanged" signal.
(Client.bump_timeout): Emit "self.PropertyChanged" signal for
"last_checked_ok".
(Client.start_checker): Emit "self.PropertyChanged" signal for
"checker_running".
(Client.stop_checker): Emit "self.PropertyChanged" signal for
"checker_running".
(Client.still_valid): Bug fix: use "getattr(self, started, False)"
instead of "self.started" in case this client
object is so new that the "started" attribute
has not been created yet.
(Client.IntervalChanged, Client.CheckerIsRunning, Client.GetChecker,
Client.GetCreated, Client.GetFingerprint, Client.GetHost,
Client.GetInterval, Client.GetName, Client.GetStarted,
Client.GetTimeout, Client.StateChanged, Client.TimeoutChanged):
Removed; all callers changed.
(Client.CheckerCompleted): Add "condition" and "command" arguments.
All callers changed.
(Client.GetAllProperties, Client.PropertyChanged): New.
(Client.StillValid): Renamed to "IsStillValid".
(Client.StartChecker): Changed to its own function to avoid the
return value from "Client.start_checker()".
(Client.Stop): Changed to its own function to avoid the return value
from "Client.stop()".
(main): Try "_mandos" before "mandos" as user and group name.
Removed inner function "remove_from_clients". New inner
class "MandosServer".
change user/group name to "_mandos".
* debian/mandos.postinst: Rename old "mandos" user and group to
"_mandos"; create "_mandos" user and group
if none exist.
* debian/mandos-client.postinst: - '' -
* initramfs-tools-hook: Try "_mandos" before "mandos" as user and
group name.
* mandos (_datetime_to_dbus_struct): New; was previously local.
(Client.started): Renamed to "last_started". All users changed.
(Client.started): New; boolean.
(Client.dbus_object_path): New.
(Client.check_command): Renamed to "checker_command". All users
changed.
(Client.__init__): Set and use "self.dbus_object_path". Set
"self.started".
(Client.start): Update "self.started". Emit "self.PropertyChanged"
signals for both "started" and "last_started".
(Client.stop): Update "self.started". Emit "self.PropertyChanged"
signal for "started".
(Client.checker_callback): Take additional "command" argument. All
callers changed. Emit
"self.PropertyChanged" signal.
(Client.bump_timeout): Emit "self.PropertyChanged" signal for
"last_checked_ok".
(Client.start_checker): Emit "self.PropertyChanged" signal for
"checker_running".
(Client.stop_checker): Emit "self.PropertyChanged" signal for
"checker_running".
(Client.still_valid): Bug fix: use "getattr(self, started, False)"
instead of "self.started" in case this client
object is so new that the "started" attribute
has not been created yet.
(Client.IntervalChanged, Client.CheckerIsRunning, Client.GetChecker,
Client.GetCreated, Client.GetFingerprint, Client.GetHost,
Client.GetInterval, Client.GetName, Client.GetStarted,
Client.GetTimeout, Client.StateChanged, Client.TimeoutChanged):
Removed; all callers changed.
(Client.CheckerCompleted): Add "condition" and "command" arguments.
All callers changed.
(Client.GetAllProperties, Client.PropertyChanged): New.
(Client.StillValid): Renamed to "IsStillValid".
(Client.StartChecker): Changed to its own function to avoid the
return value from "Client.start_checker()".
(Client.Stop): Changed to its own function to avoid the return value
from "Client.stop()".
(main): Try "_mandos" before "mandos" as user and group name.
Removed inner function "remove_from_clients". New inner
class "MandosServer".
- files added:
- debian/mandos-client.config
- files removed:
- debian/watch
- files modified:
- INSTALL
added
removed
plugins.d/mandos-client.c
1
1
/* -*- coding: utf-8 -*- */
2
2
/*
3
* Mandos-client - get and decrypt data from a Mandos server
3
* Mandos client - get and decrypt data from a Mandos server
4
4
*
5
5
* This program is partly derived from an example program for an Avahi
6
6
* service browser, downloaded from
9
9
* "browse_callback", and parts of "main".
10
10
*
11
11
* Everything else is
12
* Copyright © 2008,2009 Teddy Hogeborn
13
* Copyright © 2008,2009 Björn Påhlsson
12
* Copyright © 2008 Teddy Hogeborn
13
* Copyright © 2008 Björn Påhlsson
14
14
*
15
15
* This program is free software: you can redistribute it and/or
16
16
* modify it under the terms of the GNU General Public License as
30
30
*/
31
31
32
32
/* Needed by GPGME, specifically gpgme_data_seek() */
33
#ifndef _LARGEFILE_SOURCE
34
33
#define _LARGEFILE_SOURCE
35
#endif
36
#ifndef _FILE_OFFSET_BITS
37
34
#define _FILE_OFFSET_BITS 64
38
#endif
39
35
40
36
#define _GNU_SOURCE /* TEMP_FAILURE_RETRY(), asprintf() */
41
37
42
38
#include <stdio.h> /* fprintf(), stderr, fwrite(),
43
stdout, ferror(), remove() */
39
stdout, ferror() */
44
40
#include <stdint.h> /* uint16_t, uint32_t */
45
41
#include <stddef.h> /* NULL, size_t, ssize_t */
46
42
#include <stdlib.h> /* free(), EXIT_SUCCESS, EXIT_FAILURE,
47
srand(), strtof() */
48
#include <stdbool.h> /* bool, false, true */
43
srand() */
44
#include <stdbool.h> /* bool, true */
49
45
#include <string.h> /* memset(), strcmp(), strlen(),
50
46
strerror(), asprintf(), strcpy() */
51
#include <sys/ioctl.h> /* ioctl */
47
#include <sys/ioctl.h> /* ioctl */
52
48
#include <sys/types.h> /* socket(), inet_pton(), sockaddr,
53
49
sockaddr_in6, PF_INET6,
54
SOCK_STREAM, uid_t, gid_t, open(),
55
opendir(), DIR */
50
SOCK_STREAM, INET6_ADDRSTRLEN,
51
uid_t, gid_t, open(), opendir(), DIR */
56
52
#include <sys/stat.h> /* open() */
57
53
#include <sys/socket.h> /* socket(), struct sockaddr_in6,
58
inet_pton(), connect() */
54
struct in6_addr, inet_pton(),
55
connect() */
59
56
#include <fcntl.h> /* open() */
60
#include <dirent.h> /* opendir(), struct dirent, readdir()
61
*/
62
#include <inttypes.h> /* PRIu16, PRIdMAX, intmax_t,
63
strtoimax() */
57
#include <dirent.h> /* opendir(), struct dirent, readdir() */
58
#include <inttypes.h> /* PRIu16 */
64
59
#include <assert.h> /* assert() */
65
60
#include <errno.h> /* perror(), errno */
66
#include <time.h> /* nanosleep(), time() */
61
#include <time.h> /* time() */
67
62
#include <net/if.h> /* ioctl, ifreq, SIOCGIFFLAGS, IFF_UP,
68
63
SIOCSIFFLAGS, if_indextoname(),
69
64
if_nametoindex(), IF_NAMESIZE */
70
#include <netinet/in.h> /* IN6_IS_ADDR_LINKLOCAL,
71
INET_ADDRSTRLEN, INET6_ADDRSTRLEN
72
*/
65
#include <netinet/in.h>
73
66
#include <unistd.h> /* close(), SEEK_SET, off_t, write(),
74
getuid(), getgid(), seteuid(),
67
getuid(), getgid(), setuid(),
75
68
setgid() */
76
69
#include <arpa/inet.h> /* inet_pton(), htons */
77
#include <iso646.h> /* not, or, and */
70
#include <iso646.h> /* not, and */
78
71
#include <argp.h> /* struct argp_option, error_t, struct
79
72
argp_state, struct argp,
80
73
argp_parse(), ARGP_KEY_ARG,
81
74
ARGP_KEY_END, ARGP_ERR_UNKNOWN */
82
#include <signal.h> /* sigemptyset(), sigaddset(),
83
sigaction(), SIGTERM, sig_atomic_t,
84
raise() */
85
86
#ifdef __linux__
87
#include <sys/klog.h> /* klogctl() */
88
#endif /* __linux__ */
89
75
90
76
/* Avahi */
91
77
/* All Avahi types, constants and functions
104
90
gnutls_*
105
91
init_gnutls_session(),
106
92
GNUTLS_* */
107
#include <gnutls/openpgp.h>
108
/* gnutls_certificate_set_openpgp_key_file(),
93
#include <gnutls/openpgp.h> /* gnutls_certificate_set_openpgp_key_file(),
109
94
GNUTLS_OPENPGP_FMT_BASE64 */
110
95
111
96
/* GPGME */
137
122
gpgme_ctx_t ctx;
138
123
} mandos_context;
139
124
140
/* global context so signal handler can reach it*/
141
mandos_context mc = { .simple_poll = NULL, .server = NULL,
142
.dh_bits = 1024, .priority = "SECURE256"
143
":!CTYPE-X.509:+CTYPE-OPENPGP" };
144
145
sig_atomic_t quit_now = 0;
146
int signal_received = 0;
147
148
125
/*
149
* Make additional room in "buffer" for at least BUFFER_SIZE more
150
* bytes. "buffer_capacity" is how much is currently allocated,
126
* Make room in "buffer" for at least BUFFER_SIZE additional bytes.
127
* "buffer_capacity" is how much is currently allocated,
151
128
* "buffer_length" is how much is already used.
152
129
*/
153
size_t incbuffer(char **buffer, size_t buffer_length,
130
size_t adjustbuffer(char **buffer, size_t buffer_length,
154
131
size_t buffer_capacity){
155
if(buffer_length + BUFFER_SIZE > buffer_capacity){
132
if (buffer_length + BUFFER_SIZE > buffer_capacity){
156
133
*buffer = realloc(*buffer, buffer_capacity + BUFFER_SIZE);
157
if(buffer == NULL){
134
if (buffer == NULL){
158
135
return 0;
159
136
}
160
137
buffer_capacity += BUFFER_SIZE;
165
142
/*
166
143
* Initialize GPGME.
167
144
*/
168
static bool init_gpgme(const char *seckey,
145
static bool init_gpgme(mandos_context *mc, const char *seckey,
169
146
const char *pubkey, const char *tempdir){
147
int ret;
170
148
gpgme_error_t rc;
171
149
gpgme_engine_info_t engine_info;
172
150
173
151
174
152
/*
175
* Helper function to insert pub and seckey to the engine keyring.
153
* Helper function to insert pub and seckey to the enigne keyring.
176
154
*/
177
155
bool import_key(const char *filename){
178
int ret;
179
156
int fd;
180
157
gpgme_data_t pgp_data;
181
158
182
fd = (int)TEMP_FAILURE_RETRY(open(filename, O_RDONLY));
159
fd = TEMP_FAILURE_RETRY(open(filename, O_RDONLY));
183
160
if(fd == -1){
184
161
perror("open");
185
162
return false;
186
163
}
187
164
188
165
rc = gpgme_data_new_from_fd(&pgp_data, fd);
189
if(rc != GPG_ERR_NO_ERROR){
166
if (rc != GPG_ERR_NO_ERROR){
190
167
fprintf(stderr, "bad gpgme_data_new_from_fd: %s: %s\n",
191
168
gpgme_strsource(rc), gpgme_strerror(rc));
192
169
return false;
193
170
}
194
171
195
rc = gpgme_op_import(mc.ctx, pgp_data);
196
if(rc != GPG_ERR_NO_ERROR){
172
rc = gpgme_op_import(mc->ctx, pgp_data);
173
if (rc != GPG_ERR_NO_ERROR){
197
174
fprintf(stderr, "bad gpgme_op_import: %s: %s\n",
198
175
gpgme_strsource(rc), gpgme_strerror(rc));
199
176
return false;
200
177
}
201
178
202
ret = (int)TEMP_FAILURE_RETRY(close(fd));
179
ret = TEMP_FAILURE_RETRY(close(fd));
203
180
if(ret == -1){
204
181
perror("close");
205
182
}
207
184
return true;
208
185
}
209
186
210
if(debug){
211
fprintf(stderr, "Initializing GPGME\n");
187
if (debug){
188
fprintf(stderr, "Initialize gpgme\n");
212
189
}
213
190
214
191
/* Init GPGME */
215
192
gpgme_check_version(NULL);
216
193
rc = gpgme_engine_check_version(GPGME_PROTOCOL_OpenPGP);
217
if(rc != GPG_ERR_NO_ERROR){
194
if (rc != GPG_ERR_NO_ERROR){
218
195
fprintf(stderr, "bad gpgme_engine_check_version: %s: %s\n",
219
196
gpgme_strsource(rc), gpgme_strerror(rc));
220
197
return false;
221
198
}
222
199
223
200
/* Set GPGME home directory for the OpenPGP engine only */
224
rc = gpgme_get_engine_info(&engine_info);
225
if(rc != GPG_ERR_NO_ERROR){
201
rc = gpgme_get_engine_info (&engine_info);
202
if (rc != GPG_ERR_NO_ERROR){
226
203
fprintf(stderr, "bad gpgme_get_engine_info: %s: %s\n",
227
204
gpgme_strsource(rc), gpgme_strerror(rc));
228
205
return false;
241
218
}
242
219
243
220
/* Create new GPGME "context" */
244
rc = gpgme_new(&(mc.ctx));
245
if(rc != GPG_ERR_NO_ERROR){
221
rc = gpgme_new(&(mc->ctx));
222
if (rc != GPG_ERR_NO_ERROR){
246
223
fprintf(stderr, "bad gpgme_new: %s: %s\n",
247
224
gpgme_strsource(rc), gpgme_strerror(rc));
248
225
return false;
249
226
}
250
227
251
if(not import_key(pubkey) or not import_key(seckey)){
228
if (not import_key(pubkey) or not import_key(seckey)){
252
229
return false;
253
230
}
254
231
255
return true;
232
return true;
256
233
}
257
234
258
235
/*
259
236
* Decrypt OpenPGP data.
260
237
* Returns -1 on error
261
238
*/
262
static ssize_t pgp_packet_decrypt(const char *cryptotext,
263
size_t crypto_size,
264
char **plaintext){
239
static ssize_t pgp_packet_decrypt (const mandos_context *mc,
240
const char *cryptotext,
241
size_t crypto_size,
242
char **plaintext){
265
243
gpgme_data_t dh_crypto, dh_plain;
266
244
gpgme_error_t rc;
267
245
ssize_t ret;
268
246
size_t plaintext_capacity = 0;
269
247
ssize_t plaintext_length = 0;
270
248
271
if(debug){
249
if (debug){
272
250
fprintf(stderr, "Trying to decrypt OpenPGP data\n");
273
251
}
274
252
275
253
/* Create new GPGME data buffer from memory cryptotext */
276
254
rc = gpgme_data_new_from_mem(&dh_crypto, cryptotext, crypto_size,
277
255
0);
278
if(rc != GPG_ERR_NO_ERROR){
256
if (rc != GPG_ERR_NO_ERROR){
279
257
fprintf(stderr, "bad gpgme_data_new_from_mem: %s: %s\n",
280
258
gpgme_strsource(rc), gpgme_strerror(rc));
281
259
return -1;
283
261
284
262
/* Create new empty GPGME data buffer for the plaintext */
285
263
rc = gpgme_data_new(&dh_plain);
286
if(rc != GPG_ERR_NO_ERROR){
264
if (rc != GPG_ERR_NO_ERROR){
287
265
fprintf(stderr, "bad gpgme_data_new: %s: %s\n",
288
266
gpgme_strsource(rc), gpgme_strerror(rc));
289
267
gpgme_data_release(dh_crypto);
292
270
293
271
/* Decrypt data from the cryptotext data buffer to the plaintext
294
272
data buffer */
295
rc = gpgme_op_decrypt(mc.ctx, dh_crypto, dh_plain);
296
if(rc != GPG_ERR_NO_ERROR){
273
rc = gpgme_op_decrypt(mc->ctx, dh_crypto, dh_plain);
274
if (rc != GPG_ERR_NO_ERROR){
297
275
fprintf(stderr, "bad gpgme_op_decrypt: %s: %s\n",
298
276
gpgme_strsource(rc), gpgme_strerror(rc));
299
277
plaintext_length = -1;
300
if(debug){
278
if (debug){
301
279
gpgme_decrypt_result_t result;
302
result = gpgme_op_decrypt_result(mc.ctx);
303
if(result == NULL){
280
result = gpgme_op_decrypt_result(mc->ctx);
281
if (result == NULL){
304
282
fprintf(stderr, "gpgme_op_decrypt_result failed\n");
305
283
} else {
306
284
fprintf(stderr, "Unsupported algorithm: %s\n",
312
290
}
313
291
gpgme_recipient_t recipient;
314
292
recipient = result->recipients;
315
while(recipient != NULL){
316
fprintf(stderr, "Public key algorithm: %s\n",
317
gpgme_pubkey_algo_name(recipient->pubkey_algo));
318
fprintf(stderr, "Key ID: %s\n", recipient->keyid);
319
fprintf(stderr, "Secret key available: %s\n",
320
recipient->status == GPG_ERR_NO_SECKEY
321
? "No" : "Yes");
322
recipient = recipient->next;
293
if(recipient){
294
while(recipient != NULL){
295
fprintf(stderr, "Public key algorithm: %s\n",
296
gpgme_pubkey_algo_name(recipient->pubkey_algo));
297
fprintf(stderr, "Key ID: %s\n", recipient->keyid);
298
fprintf(stderr, "Secret key available: %s\n",
299
recipient->status == GPG_ERR_NO_SECKEY
300
? "No" : "Yes");
301
recipient = recipient->next;
302
}
323
303
}
324
304
}
325
305
}
331
311
}
332
312
333
313
/* Seek back to the beginning of the GPGME plaintext data buffer */
334
if(gpgme_data_seek(dh_plain, (off_t)0, SEEK_SET) == -1){
314
if (gpgme_data_seek(dh_plain, (off_t) 0, SEEK_SET) == -1){
335
315
perror("gpgme_data_seek");
336
316
plaintext_length = -1;
337
317
goto decrypt_end;
339
319
340
320
*plaintext = NULL;
341
321
while(true){
342
plaintext_capacity = incbuffer(plaintext,
322
plaintext_capacity = adjustbuffer(plaintext,
343
323
(size_t)plaintext_length,
344
324
plaintext_capacity);
345
if(plaintext_capacity == 0){
346
perror("incbuffer");
325
if (plaintext_capacity == 0){
326
perror("adjustbuffer");
347
327
plaintext_length = -1;
348
328
goto decrypt_end;
349
329
}
351
331
ret = gpgme_data_read(dh_plain, *plaintext + plaintext_length,
352
332
BUFFER_SIZE);
353
333
/* Print the data, if any */
354
if(ret == 0){
334
if (ret == 0){
355
335
/* EOF */
356
336
break;
357
337
}
381
361
return plaintext_length;
382
362
}
383
363
384
static const char * safer_gnutls_strerror(int value){
385
const char *ret = gnutls_strerror(value); /* Spurious warning from
386
-Wunreachable-code */
387
if(ret == NULL)
364
static const char * safer_gnutls_strerror (int value) {
365
const char *ret = gnutls_strerror (value); /* Spurious warning */
366
if (ret == NULL)
388
367
ret = "(unknown)";
389
368
return ret;
390
369
}
395
374
fprintf(stderr, "GnuTLS: %s", string);
396
375
}
397
376
398
static int init_gnutls_global(const char *pubkeyfilename,
377
static int init_gnutls_global(mandos_context *mc,
378
const char *pubkeyfilename,
399
379
const char *seckeyfilename){
400
380
int ret;
401
381
404
384
}
405
385
406
386
ret = gnutls_global_init();
407
if(ret != GNUTLS_E_SUCCESS){
408
fprintf(stderr, "GnuTLS global_init: %s\n",
409
safer_gnutls_strerror(ret));
387
if (ret != GNUTLS_E_SUCCESS) {
388
fprintf (stderr, "GnuTLS global_init: %s\n",
389
safer_gnutls_strerror(ret));
410
390
return -1;
411
391
}
412
392
413
if(debug){
393
if (debug){
414
394
/* "Use a log level over 10 to enable all debugging options."
415
395
* - GnuTLS manual
416
396
*/
419
399
}
420
400
421
401
/* OpenPGP credentials */
422
gnutls_certificate_allocate_credentials(&mc.cred);
423
if(ret != GNUTLS_E_SUCCESS){
424
fprintf(stderr, "GnuTLS memory error: %s\n", /* Spurious warning
425
from
426
-Wunreachable-code
427
*/
428
safer_gnutls_strerror(ret));
429
gnutls_global_deinit();
402
gnutls_certificate_allocate_credentials(&mc->cred);
403
if (ret != GNUTLS_E_SUCCESS){
404
fprintf (stderr, "GnuTLS memory error: %s\n", /* Spurious
405
warning */
406
safer_gnutls_strerror(ret));
407
gnutls_global_deinit ();
430
408
return -1;
431
409
}
432
410
437
415
}
438
416
439
417
ret = gnutls_certificate_set_openpgp_key_file
440
(mc.cred, pubkeyfilename, seckeyfilename,
418
(mc->cred, pubkeyfilename, seckeyfilename,
441
419
GNUTLS_OPENPGP_FMT_BASE64);
442
if(ret != GNUTLS_E_SUCCESS){
420
if (ret != GNUTLS_E_SUCCESS) {
443
421
fprintf(stderr,
444
422
"Error[%d] while reading the OpenPGP key pair ('%s',"
445
423
" '%s')\n", ret, pubkeyfilename, seckeyfilename);
449
427
}
450
428
451
429
/* GnuTLS server initialization */
452
ret = gnutls_dh_params_init(&mc.dh_params);
453
if(ret != GNUTLS_E_SUCCESS){
454
fprintf(stderr, "Error in GnuTLS DH parameter initialization:"
455
" %s\n", safer_gnutls_strerror(ret));
430
ret = gnutls_dh_params_init(&mc->dh_params);
431
if (ret != GNUTLS_E_SUCCESS) {
432
fprintf (stderr, "Error in GnuTLS DH parameter initialization:"
433
" %s\n", safer_gnutls_strerror(ret));
456
434
goto globalfail;
457
435
}
458
ret = gnutls_dh_params_generate2(mc.dh_params, mc.dh_bits);
459
if(ret != GNUTLS_E_SUCCESS){
460
fprintf(stderr, "Error in GnuTLS prime generation: %s\n",
461
safer_gnutls_strerror(ret));
436
ret = gnutls_dh_params_generate2(mc->dh_params, mc->dh_bits);
437
if (ret != GNUTLS_E_SUCCESS) {
438
fprintf (stderr, "Error in GnuTLS prime generation: %s\n",
439
safer_gnutls_strerror(ret));
462
440
goto globalfail;
463
441
}
464
442
465
gnutls_certificate_set_dh_params(mc.cred, mc.dh_params);
443
gnutls_certificate_set_dh_params(mc->cred, mc->dh_params);
466
444
467
445
return 0;
468
446
469
447
globalfail:
470
448
471
gnutls_certificate_free_credentials(mc.cred);
449
gnutls_certificate_free_credentials(mc->cred);
472
450
gnutls_global_deinit();
473
gnutls_dh_params_deinit(mc.dh_params);
451
gnutls_dh_params_deinit(mc->dh_params);
474
452
return -1;
475
453
}
476
454
477
static int init_gnutls_session(gnutls_session_t *session){
455
static int init_gnutls_session(mandos_context *mc,
456
gnutls_session_t *session){
478
457
int ret;
479
458
/* GnuTLS session creation */
480
do {
481
ret = gnutls_init(session, GNUTLS_SERVER);
482
if(quit_now){
483
return -1;
484
}
485
} while(ret == GNUTLS_E_INTERRUPTED or ret == GNUTLS_E_AGAIN);
486
if(ret != GNUTLS_E_SUCCESS){
459
ret = gnutls_init(session, GNUTLS_SERVER);
460
if (ret != GNUTLS_E_SUCCESS){
487
461
fprintf(stderr, "Error in GnuTLS session initialization: %s\n",
488
462
safer_gnutls_strerror(ret));
489
463
}
490
464
491
465
{
492
466
const char *err;
493
do {
494
ret = gnutls_priority_set_direct(*session, mc.priority, &err);
495
if(quit_now){
496
gnutls_deinit(*session);
497
return -1;
498
}
499
} while(ret == GNUTLS_E_INTERRUPTED or ret == GNUTLS_E_AGAIN);
500
if(ret != GNUTLS_E_SUCCESS){
467
ret = gnutls_priority_set_direct(*session, mc->priority, &err);
468
if (ret != GNUTLS_E_SUCCESS) {
501
469
fprintf(stderr, "Syntax error at: %s\n", err);
502
470
fprintf(stderr, "GnuTLS error: %s\n",
503
471
safer_gnutls_strerror(ret));
504
gnutls_deinit(*session);
472
gnutls_deinit (*session);
505
473
return -1;
506
474
}
507
475
}
508
476
509
do {
510
ret = gnutls_credentials_set(*session, GNUTLS_CRD_CERTIFICATE,
511
mc.cred);
512
if(quit_now){
513
gnutls_deinit(*session);
514
return -1;
515
}
516
} while(ret == GNUTLS_E_INTERRUPTED or ret == GNUTLS_E_AGAIN);
517
if(ret != GNUTLS_E_SUCCESS){
477
ret = gnutls_credentials_set(*session, GNUTLS_CRD_CERTIFICATE,
478
mc->cred);
479
if (ret != GNUTLS_E_SUCCESS) {
518
480
fprintf(stderr, "Error setting GnuTLS credentials: %s\n",
519
481
safer_gnutls_strerror(ret));
520
gnutls_deinit(*session);
482
gnutls_deinit (*session);
521
483
return -1;
522
484
}
523
485
524
486
/* ignore client certificate if any. */
525
gnutls_certificate_server_set_request(*session, GNUTLS_CERT_IGNORE);
487
gnutls_certificate_server_set_request (*session,
488
GNUTLS_CERT_IGNORE);
526
489
527
gnutls_dh_set_prime_bits(*session, mc.dh_bits);
490
gnutls_dh_set_prime_bits (*session, mc->dh_bits);
528
491
529
492
return 0;
530
493
}
536
499
/* Called when a Mandos server is found */
537
500
static int start_mandos_communication(const char *ip, uint16_t port,
538
501
AvahiIfIndex if_index,
539
int af){
540
int ret, tcp_sd = -1;
541
ssize_t sret;
542
union {
543
struct sockaddr_in in;
544
struct sockaddr_in6 in6;
545
} to;
502
mandos_context *mc){
503
int ret, tcp_sd;
504
union { struct sockaddr in; struct sockaddr_in6 in6; } to;
546
505
char *buffer = NULL;
547
506
char *decrypted_buffer;
548
507
size_t buffer_length = 0;
549
508
size_t buffer_capacity = 0;
509
ssize_t decrypted_buffer_size;
550
510
size_t written;
551
511
int retval = 0;
512
char interface[IF_NAMESIZE];
552
513
gnutls_session_t session;
553
int pf; /* Protocol family */
554
555
if(quit_now){
556
return -1;
557
}
558
559
switch(af){
560
case AF_INET6:
561
pf = PF_INET6;
562
break;
563
case AF_INET:
564
pf = PF_INET;
565
break;
566
default:
567
fprintf(stderr, "Bad address family: %d\n", af);
568
return -1;
569
}
570
571
ret = init_gnutls_session(&session);
572
if(ret != 0){
514
515
ret = init_gnutls_session (mc, &session);
516
if (ret != 0){
573
517
return -1;
574
518
}
575
519
576
520
if(debug){
577
fprintf(stderr, "Setting up a TCP connection to %s, port %" PRIu16
521
fprintf(stderr, "Setting up a tcp connection to %s, port %" PRIu16
578
522
"\n", ip, port);
579
523
}
580
524
581
tcp_sd = socket(pf, SOCK_STREAM, 0);
582
if(tcp_sd < 0){
525
tcp_sd = socket(PF_INET6, SOCK_STREAM, 0);
526
if(tcp_sd < 0) {
583
527
perror("socket");
584
retval = -1;
585
goto mandos_end;
528
return -1;
586
529
}
587
530
588
if(quit_now){
589
retval = -1;
590
goto mandos_end;
531
if(debug){
532
if(if_indextoname((unsigned int)if_index, interface) == NULL){
533
perror("if_indextoname");
534
return -1;
535
}
536
fprintf(stderr, "Binding to interface %s\n", interface);
591
537
}
592
538
593
539
memset(&to, 0, sizeof(to));
594
if(af == AF_INET6){
595
to.in6.sin6_family = (sa_family_t)af;
596
ret = inet_pton(af, ip, &to.in6.sin6_addr);
597
} else { /* IPv4 */
598
to.in.sin_family = (sa_family_t)af;
599
ret = inet_pton(af, ip, &to.in.sin_addr);
600
}
601
if(ret < 0 ){
540
to.in6.sin6_family = AF_INET6;
541
/* It would be nice to have a way to detect if we were passed an
542
IPv4 address here. Now we assume an IPv6 address. */
543
ret = inet_pton(AF_INET6, ip, &to.in6.sin6_addr);
544
if (ret < 0 ){
602
545
perror("inet_pton");
603
retval = -1;
604
goto mandos_end;
546
return -1;
605
547
}
606
548
if(ret == 0){
607
549
fprintf(stderr, "Bad address: %s\n", ip);
608
retval = -1;
609
goto mandos_end;
610
}
611
if(af == AF_INET6){
612
to.in6.sin6_port = htons(port); /* Spurious warnings from
613
-Wconversion and
614
-Wunreachable-code */
615
616
if(IN6_IS_ADDR_LINKLOCAL /* Spurious warnings from */
617
(&to.in6.sin6_addr)){ /* -Wstrict-aliasing=2 or lower and
618
-Wunreachable-code*/
619
if(if_index == AVAHI_IF_UNSPEC){
620
fprintf(stderr, "An IPv6 link-local address is incomplete"
621
" without a network interface\n");
622
retval = -1;
623
goto mandos_end;
624
}
625
/* Set the network interface number as scope */
626
to.in6.sin6_scope_id = (uint32_t)if_index;
627
}
628
} else {
629
to.in.sin_port = htons(port); /* Spurious warnings from
630
-Wconversion and
631
-Wunreachable-code */
632
}
550
return -1;
551
}
552
to.in6.sin6_port = htons(port); /* Spurious warning */
633
553
634
if(quit_now){
635
retval = -1;
636
goto mandos_end;
637
}
554
to.in6.sin6_scope_id = (uint32_t)if_index;
638
555
639
556
if(debug){
640
if(af == AF_INET6 and if_index != AVAHI_IF_UNSPEC){
641
char interface[IF_NAMESIZE];
642
if(if_indextoname((unsigned int)if_index, interface) == NULL){
643
perror("if_indextoname");
644
} else {
645
fprintf(stderr, "Connection to: %s%%%s, port %" PRIu16 "\n",
646
ip, interface, port);
647
}
648
} else {
649
fprintf(stderr, "Connection to: %s, port %" PRIu16 "\n", ip,
650
port);
651
}
652
char addrstr[(INET_ADDRSTRLEN > INET6_ADDRSTRLEN) ?
653
INET_ADDRSTRLEN : INET6_ADDRSTRLEN] = "";
654
const char *pcret;
655
if(af == AF_INET6){
656
pcret = inet_ntop(af, &(to.in6.sin6_addr), addrstr,
657
sizeof(addrstr));
658
} else {
659
pcret = inet_ntop(af, &(to.in.sin_addr), addrstr,
660
sizeof(addrstr));
661
}
662
if(pcret == NULL){
557
fprintf(stderr, "Connection to: %s, port %" PRIu16 "\n", ip,
558
port);
559
char addrstr[INET6_ADDRSTRLEN] = "";
560
if(inet_ntop(to.in6.sin6_family, &(to.in6.sin6_addr), addrstr,
561
sizeof(addrstr)) == NULL){
663
562
perror("inet_ntop");
664
563
} else {
665
564
if(strcmp(addrstr, ip) != 0){
668
567
}
669
568
}
670
569
671
if(quit_now){
672
retval = -1;
673
goto mandos_end;
674
}
675
676
if(af == AF_INET6){
677
ret = connect(tcp_sd, &to.in6, sizeof(to));
678
} else {
679
ret = connect(tcp_sd, &to.in, sizeof(to)); /* IPv4 */
680
}
681
if(ret < 0){
570
ret = connect(tcp_sd, &to.in, sizeof(to));
571
if (ret < 0){
682
572
perror("connect");
683
retval = -1;
684
goto mandos_end;
685
}
686
687
if(quit_now){
688
retval = -1;
689
goto mandos_end;
573
return -1;
690
574
}
691
575
692
576
const char *out = mandos_protocol_version;
693
577
written = 0;
694
while(true){
578
while (true){
695
579
size_t out_size = strlen(out);
696
ret = (int)TEMP_FAILURE_RETRY(write(tcp_sd, out + written,
580
ret = TEMP_FAILURE_RETRY(write(tcp_sd, out + written,
697
581
out_size - written));
698
if(ret == -1){
582
if (ret == -1){
699
583
perror("write");
700
584
retval = -1;
701
585
goto mandos_end;
704
588
if(written < out_size){
705
589
continue;
706
590
} else {
707
if(out == mandos_protocol_version){
591
if (out == mandos_protocol_version){
708
592
written = 0;
709
593
out = "\r\n";
710
594
} else {
711
595
break;
712
596
}
713
597
}
714
715
if(quit_now){
716
retval = -1;
717
goto mandos_end;
718
}
719
598
}
720
599
721
600
if(debug){
722
601
fprintf(stderr, "Establishing TLS session with %s\n", ip);
723
602
}
724
603
725
if(quit_now){
726
retval = -1;
727
goto mandos_end;
728
}
729
730
gnutls_transport_set_ptr(session, (gnutls_transport_ptr_t) tcp_sd);
731
732
if(quit_now){
733
retval = -1;
734
goto mandos_end;
735
}
736
737
do {
738
ret = gnutls_handshake(session);
739
if(quit_now){
740
retval = -1;
741
goto mandos_end;
742
}
604
gnutls_transport_set_ptr (session, (gnutls_transport_ptr_t) tcp_sd);
605
606
do{
607
ret = gnutls_handshake (session);
743
608
} while(ret == GNUTLS_E_AGAIN or ret == GNUTLS_E_INTERRUPTED);
744
609
745
if(ret != GNUTLS_E_SUCCESS){
610
if (ret != GNUTLS_E_SUCCESS){
746
611
if(debug){
747
612
fprintf(stderr, "*** GnuTLS Handshake failed ***\n");
748
gnutls_perror(ret);
613
gnutls_perror (ret);
749
614
}
750
615
retval = -1;
751
616
goto mandos_end;
754
619
/* Read OpenPGP packet that contains the wanted password */
755
620
756
621
if(debug){
757
fprintf(stderr, "Retrieving OpenPGP encrypted password from %s\n",
622
fprintf(stderr, "Retrieving pgp encrypted password from %s\n",
758
623
ip);
759
624
}
760
625
761
626
while(true){
762
763
if(quit_now){
764
retval = -1;
765
goto mandos_end;
766
}
767
768
buffer_capacity = incbuffer(&buffer, buffer_length,
627
buffer_capacity = adjustbuffer(&buffer, buffer_length,
769
628
buffer_capacity);
770
if(buffer_capacity == 0){
771
perror("incbuffer");
772
retval = -1;
773
goto mandos_end;
774
}
775
776
if(quit_now){
777
retval = -1;
778
goto mandos_end;
779
}
780
781
sret = gnutls_record_recv(session, buffer+buffer_length,
782
BUFFER_SIZE);
783
if(sret == 0){
629
if (buffer_capacity == 0){
630
perror("adjustbuffer");
631
retval = -1;
632
goto mandos_end;
633
}
634
635
ret = gnutls_record_recv(session, buffer+buffer_length,
636
BUFFER_SIZE);
637
if (ret == 0){
784
638
break;
785
639
}
786
if(sret < 0){
787
switch(sret){
640
if (ret < 0){
641
switch(ret){
788
642
case GNUTLS_E_INTERRUPTED:
789
643
case GNUTLS_E_AGAIN:
790
644
break;
791
645
case GNUTLS_E_REHANDSHAKE:
792
do {
793
ret = gnutls_handshake(session);
794
795
if(quit_now){
796
retval = -1;
797
goto mandos_end;
798
}
646
do{
647
ret = gnutls_handshake (session);
799
648
} while(ret == GNUTLS_E_AGAIN or ret == GNUTLS_E_INTERRUPTED);
800
if(ret < 0){
649
if (ret < 0){
801
650
fprintf(stderr, "*** GnuTLS Re-handshake failed ***\n");
802
gnutls_perror(ret);
651
gnutls_perror (ret);
803
652
retval = -1;
804
653
goto mandos_end;
805
654
}
808
657
fprintf(stderr, "Unknown error while reading data from"
809
658
" encrypted session with Mandos server\n");
810
659
retval = -1;
811
gnutls_bye(session, GNUTLS_SHUT_RDWR);
660
gnutls_bye (session, GNUTLS_SHUT_RDWR);
812
661
goto mandos_end;
813
662
}
814
663
} else {
815
buffer_length += (size_t) sret;
664
buffer_length += (size_t) ret;
816
665
}
817
666
}
818
667
820
669
fprintf(stderr, "Closing TLS session\n");
821
670
}
822
671
823
if(quit_now){
824
retval = -1;
825
goto mandos_end;
826
}
827
828
do {
829
ret = gnutls_bye(session, GNUTLS_SHUT_RDWR);
830
if(quit_now){
831
retval = -1;
832
goto mandos_end;
833
}
834
} while(ret == GNUTLS_E_AGAIN or ret == GNUTLS_E_INTERRUPTED);
835
836
if(buffer_length > 0){
837
ssize_t decrypted_buffer_size;
838
decrypted_buffer_size = pgp_packet_decrypt(buffer,
672
gnutls_bye (session, GNUTLS_SHUT_RDWR);
673
674
if (buffer_length > 0){
675
decrypted_buffer_size = pgp_packet_decrypt(mc, buffer,
839
676
buffer_length,
840
677
&decrypted_buffer);
841
if(decrypted_buffer_size >= 0){
842
678
if (decrypted_buffer_size >= 0){
843
679
written = 0;
844
680
while(written < (size_t) decrypted_buffer_size){
845
if(quit_now){
846
retval = -1;
847
goto mandos_end;
848
}
849
850
ret = (int)fwrite(decrypted_buffer + written, 1,
851
(size_t)decrypted_buffer_size - written,
852
stdout);
681
ret = (int)fwrite (decrypted_buffer + written, 1,
682
(size_t)decrypted_buffer_size - written,
683
stdout);
853
684
if(ret == 0 and ferror(stdout)){
854
685
if(debug){
855
686
fprintf(stderr, "Error writing encrypted data: %s\n",
872
703
873
704
mandos_end:
874
705
free(buffer);
875
if(tcp_sd >= 0){
876
ret = (int)TEMP_FAILURE_RETRY(close(tcp_sd));
877
}
706
ret = TEMP_FAILURE_RETRY(close(tcp_sd));
878
707
if(ret == -1){
879
708
perror("close");
880
709
}
881
gnutls_deinit(session);
882
if(quit_now){
883
retval = -1;
884
}
710
gnutls_deinit (session);
885
711
return retval;
886
712
}
887
713
888
714
static void resolve_callback(AvahiSServiceResolver *r,
889
715
AvahiIfIndex interface,
890
AvahiProtocol proto,
716
AVAHI_GCC_UNUSED AvahiProtocol protocol,
891
717
AvahiResolverEvent event,
892
718
const char *name,
893
719
const char *type,
898
724
AVAHI_GCC_UNUSED AvahiStringList *txt,
899
725
AVAHI_GCC_UNUSED AvahiLookupResultFlags
900
726
flags,
901
AVAHI_GCC_UNUSED void* userdata){
727
void* userdata) {
728
mandos_context *mc = userdata;
902
729
assert(r);
903
730
904
731
/* Called whenever a service has been resolved successfully or
905
732
timed out */
906
733
907
if(quit_now){
908
return;
909
}
910
911
switch(event){
734
switch (event) {
912
735
default:
913
736
case AVAHI_RESOLVER_FAILURE:
914
737
fprintf(stderr, "(Avahi Resolver) Failed to resolve service '%s'"
915
738
" of type '%s' in domain '%s': %s\n", name, type, domain,
916
avahi_strerror(avahi_server_errno(mc.server)));
739
avahi_strerror(avahi_server_errno(mc->server)));
917
740
break;
918
741
919
742
case AVAHI_RESOLVER_FOUND:
922
745
avahi_address_snprint(ip, sizeof(ip), address);
923
746
if(debug){
924
747
fprintf(stderr, "Mandos server \"%s\" found on %s (%s, %"
925
PRIdMAX ") on port %" PRIu16 "\n", name, host_name,
926
ip, (intmax_t)interface, port);
748
PRIu16 ") on port %d\n", name, host_name, ip,
749
interface, port);
927
750
}
928
int ret = start_mandos_communication(ip, port, interface,
929
avahi_proto_to_af(proto));
930
if(ret == 0){
931
avahi_simple_poll_quit(mc.simple_poll);
751
int ret = start_mandos_communication(ip, port, interface, mc);
752
if (ret == 0){
753
avahi_simple_poll_quit(mc->simple_poll);
932
754
}
933
755
}
934
756
}
935
757
avahi_s_service_resolver_free(r);
936
758
}
937
759
938
static void browse_callback(AvahiSServiceBrowser *b,
939
AvahiIfIndex interface,
940
AvahiProtocol protocol,
941
AvahiBrowserEvent event,
942
const char *name,
943
const char *type,
944
const char *domain,
945
AVAHI_GCC_UNUSED AvahiLookupResultFlags
946
flags,
947
AVAHI_GCC_UNUSED void* userdata){
760
static void browse_callback( AvahiSServiceBrowser *b,
761
AvahiIfIndex interface,
762
AvahiProtocol protocol,
763
AvahiBrowserEvent event,
764
const char *name,
765
const char *type,
766
const char *domain,
767
AVAHI_GCC_UNUSED AvahiLookupResultFlags
768
flags,
769
void* userdata) {
770
mandos_context *mc = userdata;
948
771
assert(b);
949
772
950
773
/* Called whenever a new services becomes available on the LAN or
951
774
is removed from the LAN */
952
775
953
if(quit_now){
954
return;
955
}
956
957
switch(event){
776
switch (event) {
958
777
default:
959
778
case AVAHI_BROWSER_FAILURE:
960
779
961
780
fprintf(stderr, "(Avahi browser) %s\n",
962
avahi_strerror(avahi_server_errno(mc.server)));
963
avahi_simple_poll_quit(mc.simple_poll);
781
avahi_strerror(avahi_server_errno(mc->server)));
782
avahi_simple_poll_quit(mc->simple_poll);
964
783
return;
965
784
966
785
case AVAHI_BROWSER_NEW:
969
788
the callback function is called the Avahi server will free the
970
789
resolver for us. */
971
790
972
if(avahi_s_service_resolver_new(mc.server, interface, protocol,
973
name, type, domain, protocol, 0,
974
resolve_callback, NULL) == NULL)
791
if (!(avahi_s_service_resolver_new(mc->server, interface,
792
protocol, name, type, domain,
793
AVAHI_PROTO_INET6, 0,
794
resolve_callback, mc)))
975
795
fprintf(stderr, "Avahi: Failed to resolve service '%s': %s\n",
976
name, avahi_strerror(avahi_server_errno(mc.server)));
796
name, avahi_strerror(avahi_server_errno(mc->server)));
977
797
break;
978
798
979
799
case AVAHI_BROWSER_REMOVE:
988
808
}
989
809
}
990
810
991
/* stop main loop after sigterm has been called */
992
static void handle_sigterm(int sig){
993
if(quit_now){
994
return;
995
}
996
quit_now = 1;
997
signal_received = sig;
998
int old_errno = errno;
999
if(mc.simple_poll != NULL){
1000
avahi_simple_poll_quit(mc.simple_poll);
1001
}
1002
errno = old_errno;
1003
}
1004
1005
811
int main(int argc, char *argv[]){
1006
AvahiSServiceBrowser *sb = NULL;
1007
int error;
1008
int ret;
1009
intmax_t tmpmax;
1010
char *tmp;
1011
int exitcode = EXIT_SUCCESS;
1012
const char *interface = "eth0";
1013
struct ifreq network;
1014
int sd = -1;
1015
bool take_down_interface = false;
1016
uid_t uid;
1017
gid_t gid;
1018
char *connect_to = NULL;
1019
char tempdir[] = "/tmp/mandosXXXXXX";
1020
bool tempdir_created = false;
1021
AvahiIfIndex if_index = AVAHI_IF_UNSPEC;
1022
const char *seckey = PATHDIR "/" SECKEY;
1023
const char *pubkey = PATHDIR "/" PUBKEY;
1024
1025
bool gnutls_initialized = false;
1026
bool gpgme_initialized = false;
1027
float delay = 2.5f;
1028
1029
struct sigaction old_sigterm_action = { .sa_handler = SIG_DFL };
1030
struct sigaction sigterm_action = { .sa_handler = handle_sigterm };
1031
1032
uid = getuid();
1033
gid = getgid();
1034
1035
/* Lower any group privileges we might have, just to be safe */
1036
errno = 0;
1037
ret = setgid(gid);
1038
if(ret == -1){
1039
perror("setgid");
1040
}
1041
1042
/* Lower user privileges (temporarily) */
1043
errno = 0;
1044
ret = seteuid(uid);
1045
if(ret == -1){
1046
perror("seteuid");
1047
}
1048
1049
if(quit_now){
1050
goto end;
1051
}
1052
1053
{
1054
struct argp_option options[] = {
1055
{ .name = "debug", .key = 128,
1056
.doc = "Debug mode", .group = 3 },
1057
{ .name = "connect", .key = 'c',
1058
.arg = "ADDRESS:PORT",
1059
.doc = "Connect directly to a specific Mandos server",
1060
.group = 1 },
1061
{ .name = "interface", .key = 'i',
1062
.arg = "NAME",
1063
.doc = "Network interface that will be used to search for"
1064
" Mandos servers",
1065
.group = 1 },
1066
{ .name = "seckey", .key = 's',
1067
.arg = "FILE",
1068
.doc = "OpenPGP secret key file base name",
1069
.group = 1 },
1070
{ .name = "pubkey", .key = 'p',
1071
.arg = "FILE",
1072
.doc = "OpenPGP public key file base name",
1073
.group = 2 },
1074
{ .name = "dh-bits", .key = 129,
1075
.arg = "BITS",
1076
.doc = "Bit length of the prime number used in the"
1077
" Diffie-Hellman key exchange",
1078
.group = 2 },
1079
{ .name = "priority", .key = 130,
1080
.arg = "STRING",
1081
.doc = "GnuTLS priority string for the TLS handshake",
1082
.group = 1 },
1083
{ .name = "delay", .key = 131,
1084
.arg = "SECONDS",
1085
.doc = "Maximum delay to wait for interface startup",
1086
.group = 2 },
1087
{ .name = NULL }
1088
};
1089
1090
error_t parse_opt(int key, char *arg,
1091
struct argp_state *state){
1092
switch(key){
1093
case 128: /* --debug */
1094
debug = true;
1095
break;
1096
case 'c': /* --connect */
1097
connect_to = arg;
1098
break;
1099
case 'i': /* --interface */
1100
interface = arg;
1101
break;
1102
case 's': /* --seckey */
1103
seckey = arg;
1104
break;
1105
case 'p': /* --pubkey */
1106
pubkey = arg;
1107
break;
1108
case 129: /* --dh-bits */
1109
errno = 0;
1110
tmpmax = strtoimax(arg, &tmp, 10);
1111
if(errno != 0 or tmp == arg or *tmp != '\0'
1112
or tmpmax != (typeof(mc.dh_bits))tmpmax){
1113
fprintf(stderr, "Bad number of DH bits\n");
1114
exit(EXIT_FAILURE);
1115
}
1116
mc.dh_bits = (typeof(mc.dh_bits))tmpmax;
1117
break;
1118
case 130: /* --priority */
1119
mc.priority = arg;
1120
break;
1121
case 131: /* --delay */
1122
errno = 0;
1123
delay = strtof(arg, &tmp);
1124
if(errno != 0 or tmp == arg or *tmp != '\0'){
1125
fprintf(stderr, "Bad delay\n");
1126
exit(EXIT_FAILURE);
1127
}
1128
break;
1129
case ARGP_KEY_ARG:
1130
argp_usage(state);
1131
case ARGP_KEY_END:
1132
break;
1133
default:
1134
return ARGP_ERR_UNKNOWN;
1135
}
1136
return 0;
1137
}
1138
1139
struct argp argp = { .options = options, .parser = parse_opt,
1140
.args_doc = "",
1141
.doc = "Mandos client -- Get and decrypt"
1142
" passwords from a Mandos server" };
1143
ret = argp_parse(&argp, argc, argv, 0, 0, NULL);
1144
if(ret == ARGP_ERR_UNKNOWN){
1145
fprintf(stderr, "Unknown error while parsing arguments\n");
1146
exitcode = EXIT_FAILURE;
1147
goto end;
1148
}
1149
}
1150
1151
if(not debug){
1152
avahi_set_log_function(empty_log);
1153
}
1154
1155
/* Initialize Avahi early so avahi_simple_poll_quit() can be called
1156
from the signal handler */
1157
/* Initialize the pseudo-RNG for Avahi */
1158
srand((unsigned int) time(NULL));
1159
mc.simple_poll = avahi_simple_poll_new();
1160
if(mc.simple_poll == NULL){
1161
fprintf(stderr, "Avahi: Failed to create simple poll object.\n");
1162
exitcode = EXIT_FAILURE;
1163
goto end;
1164
}
1165
1166
sigemptyset(&sigterm_action.sa_mask);
1167
ret = sigaddset(&sigterm_action.sa_mask, SIGINT);
1168
if(ret == -1){
1169
perror("sigaddset");
1170
exitcode = EXIT_FAILURE;
1171
goto end;
1172
}
1173
ret = sigaddset(&sigterm_action.sa_mask, SIGHUP);
1174
if(ret == -1){
1175
perror("sigaddset");
1176
exitcode = EXIT_FAILURE;
1177
goto end;
1178
}
1179
ret = sigaddset(&sigterm_action.sa_mask, SIGTERM);
1180
if(ret == -1){
1181
perror("sigaddset");
1182
exitcode = EXIT_FAILURE;
1183
goto end;
1184
}
1185
/* Need to check if the handler is SIG_IGN before handling:
1186
| [[info:libc:Initial Signal Actions]] |
1187
| [[info:libc:Basic Signal Handling]] |
1188
*/
1189
ret = sigaction(SIGINT, NULL, &old_sigterm_action);
1190
if(ret == -1){
1191
perror("sigaction");
1192
return EXIT_FAILURE;
1193
}
1194
if(old_sigterm_action.sa_handler != SIG_IGN){
1195
ret = sigaction(SIGINT, &sigterm_action, NULL);
1196
if(ret == -1){
1197
perror("sigaction");
1198
exitcode = EXIT_FAILURE;
1199
goto end;
1200
}
1201
}
1202
ret = sigaction(SIGHUP, NULL, &old_sigterm_action);
1203
if(ret == -1){
1204
perror("sigaction");
1205
return EXIT_FAILURE;
1206
}
1207
if(old_sigterm_action.sa_handler != SIG_IGN){
1208
ret = sigaction(SIGHUP, &sigterm_action, NULL);
1209
if(ret == -1){
1210
perror("sigaction");
1211
exitcode = EXIT_FAILURE;
1212
goto end;
1213
}
1214
}
1215
ret = sigaction(SIGTERM, NULL, &old_sigterm_action);
1216
if(ret == -1){
1217
perror("sigaction");
1218
return EXIT_FAILURE;
1219
}
1220
if(old_sigterm_action.sa_handler != SIG_IGN){
1221
ret = sigaction(SIGTERM, &sigterm_action, NULL);
1222
if(ret == -1){
1223
perror("sigaction");
1224
exitcode = EXIT_FAILURE;
1225
goto end;
1226
}
1227
}
1228
1229
/* If the interface is down, bring it up */
1230
if(interface[0] != '\0'){
812
AvahiSServiceBrowser *sb = NULL;
813
int error;
814
int ret;
815
int exitcode = EXIT_SUCCESS;
816
const char *interface = "eth0";
817
struct ifreq network;
818
int sd;
819
uid_t uid;
820
gid_t gid;
821
char *connect_to = NULL;
822
char tempdir[] = "/tmp/mandosXXXXXX";
823
AvahiIfIndex if_index = AVAHI_IF_UNSPEC;
824
const char *seckey = PATHDIR "/" SECKEY;
825
const char *pubkey = PATHDIR "/" PUBKEY;
826
827
mandos_context mc = { .simple_poll = NULL, .server = NULL,
828
.dh_bits = 1024, .priority = "SECURE256"
829
":!CTYPE-X.509:+CTYPE-OPENPGP" };
830
bool gnutls_initalized = false;
831
bool gpgme_initalized = false;
832
833
{
834
struct argp_option options[] = {
835
{ .name = "debug", .key = 128,
836
.doc = "Debug mode", .group = 3 },
837
{ .name = "connect", .key = 'c',
838
.arg = "ADDRESS:PORT",
839
.doc = "Connect directly to a specific Mandos server",
840
.group = 1 },
841
{ .name = "interface", .key = 'i',
842
.arg = "NAME",
843
.doc = "Interface that will be used to search for Mandos"
844
" servers",
845
.group = 1 },
846
{ .name = "seckey", .key = 's',
847
.arg = "FILE",
848
.doc = "OpenPGP secret key file base name",
849
.group = 1 },
850
{ .name = "pubkey", .key = 'p',
851
.arg = "FILE",
852
.doc = "OpenPGP public key file base name",
853
.group = 2 },
854
{ .name = "dh-bits", .key = 129,
855
.arg = "BITS",
856
.doc = "Bit length of the prime number used in the"
857
" Diffie-Hellman key exchange",
858
.group = 2 },
859
{ .name = "priority", .key = 130,
860
.arg = "STRING",
861
.doc = "GnuTLS priority string for the TLS handshake",
862
.group = 1 },
863
{ .name = NULL }
864
};
865
866
error_t parse_opt (int key, char *arg,
867
struct argp_state *state) {
868
/* Get the INPUT argument from `argp_parse', which we know is
869
a pointer to our plugin list pointer. */
870
switch (key) {
871
case 128: /* --debug */
872
debug = true;
873
break;
874
case 'c': /* --connect */
875
connect_to = arg;
876
break;
877
case 'i': /* --interface */
878
interface = arg;
879
break;
880
case 's': /* --seckey */
881
seckey = arg;
882
break;
883
case 'p': /* --pubkey */
884
pubkey = arg;
885
break;
886
case 129: /* --dh-bits */
887
errno = 0;
888
mc.dh_bits = (unsigned int) strtol(arg, NULL, 10);
889
if (errno){
890
perror("strtol");
891
exit(EXIT_FAILURE);
892
}
893
break;
894
case 130: /* --priority */
895
mc.priority = arg;
896
break;
897
case ARGP_KEY_ARG:
898
argp_usage (state);
899
case ARGP_KEY_END:
900
break;
901
default:
902
return ARGP_ERR_UNKNOWN;
903
}
904
return 0;
905
}
906
907
struct argp argp = { .options = options, .parser = parse_opt,
908
.args_doc = "",
909
.doc = "Mandos client -- Get and decrypt"
910
" passwords from a Mandos server" };
911
ret = argp_parse (&argp, argc, argv, 0, 0, NULL);
912
if (ret == ARGP_ERR_UNKNOWN){
913
fprintf(stderr, "Unknown error while parsing arguments\n");
914
exitcode = EXIT_FAILURE;
915
goto end;
916
}
917
}
918
919
/* If the interface is down, bring it up */
920
{
921
sd = socket(PF_INET6, SOCK_DGRAM, IPPROTO_IP);
922
if(sd < 0) {
923
perror("socket");
924
exitcode = EXIT_FAILURE;
925
goto end;
926
}
927
strcpy(network.ifr_name, interface);
928
ret = ioctl(sd, SIOCGIFFLAGS, &network);
929
if(ret == -1){
930
perror("ioctl SIOCGIFFLAGS");
931
exitcode = EXIT_FAILURE;
932
goto end;
933
}
934
if((network.ifr_flags & IFF_UP) == 0){
935
network.ifr_flags |= IFF_UP;
936
ret = ioctl(sd, SIOCSIFFLAGS, &network);
937
if(ret == -1){
938
perror("ioctl SIOCSIFFLAGS");
939
exitcode = EXIT_FAILURE;
940
goto end;
941
}
942
}
943
ret = TEMP_FAILURE_RETRY(close(sd));
944
if(ret == -1){
945
perror("close");
946
}
947
}
948
949
uid = getuid();
950
gid = getgid();
951
952
ret = setuid(uid);
953
if (ret == -1){
954
perror("setuid");
955
}
956
957
setgid(gid);
958
if (ret == -1){
959
perror("setgid");
960
}
961
962
ret = init_gnutls_global(&mc, pubkey, seckey);
963
if (ret == -1){
964
fprintf(stderr, "init_gnutls_global failed\n");
965
exitcode = EXIT_FAILURE;
966
goto end;
967
} else {
968
gnutls_initalized = true;
969
}
970
971
if(mkdtemp(tempdir) == NULL){
972
perror("mkdtemp");
973
tempdir[0] = '\0';
974
goto end;
975
}
976
977
if(not init_gpgme(&mc, pubkey, seckey, tempdir)){
978
fprintf(stderr, "gpgme_initalized failed\n");
979
exitcode = EXIT_FAILURE;
980
goto end;
981
} else {
982
gpgme_initalized = true;
983
}
984
1231
985
if_index = (AvahiIfIndex) if_nametoindex(interface);
1232
986
if(if_index == 0){
1233
987
fprintf(stderr, "No such interface: \"%s\"\n", interface);
1234
exitcode = EXIT_FAILURE;
1235
goto end;
1236
}
1237
1238
if(quit_now){
1239
goto end;
1240
}
1241
1242
/* Re-raise priviliges */
1243
errno = 0;
1244
ret = seteuid(0);
1245
if(ret == -1){
1246
perror("seteuid");
1247
}
1248
1249
#ifdef __linux__
1250
/* Lower kernel loglevel to KERN_NOTICE to avoid KERN_INFO
1251
messages to mess up the prompt */
1252
ret = klogctl(8, NULL, 5);
1253
bool restore_loglevel = true;
1254
if(ret == -1){
1255
restore_loglevel = false;
1256
perror("klogctl");
1257
}
1258
#endif /* __linux__ */
1259
1260
sd = socket(PF_INET6, SOCK_DGRAM, IPPROTO_IP);
1261
if(sd < 0){
1262
perror("socket");
1263
exitcode = EXIT_FAILURE;
1264
#ifdef __linux__
1265
if(restore_loglevel){
1266
ret = klogctl(7, NULL, 0);
1267
if(ret == -1){
1268
perror("klogctl");
1269
}
1270
}
1271
#endif /* __linux__ */
1272
/* Lower privileges */
1273
errno = 0;
1274
ret = seteuid(uid);
1275
if(ret == -1){
1276
perror("seteuid");
1277
}
1278
goto end;
1279
}
1280
strcpy(network.ifr_name, interface);
1281
ret = ioctl(sd, SIOCGIFFLAGS, &network);
1282
if(ret == -1){
1283
perror("ioctl SIOCGIFFLAGS");
1284
#ifdef __linux__
1285
if(restore_loglevel){
1286
ret = klogctl(7, NULL, 0);
1287
if(ret == -1){
1288
perror("klogctl");
1289
}
1290
}
1291
#endif /* __linux__ */
1292
exitcode = EXIT_FAILURE;
1293
/* Lower privileges */
1294
errno = 0;
1295
ret = seteuid(uid);
1296
if(ret == -1){
1297
perror("seteuid");
1298
}
1299
goto end;
1300
}
1301
if((network.ifr_flags & IFF_UP) == 0){
1302
network.ifr_flags |= IFF_UP;
1303
take_down_interface = true;
1304
ret = ioctl(sd, SIOCSIFFLAGS, &network);
1305
if(ret == -1){
1306
take_down_interface = false;
1307
perror("ioctl SIOCSIFFLAGS");
1308
exitcode = EXIT_FAILURE;
1309
#ifdef __linux__
1310
if(restore_loglevel){
1311
ret = klogctl(7, NULL, 0);
1312
if(ret == -1){
1313
perror("klogctl");
1314
}
1315
}
1316
#endif /* __linux__ */
1317
/* Lower privileges */
1318
errno = 0;
1319
ret = seteuid(uid);
1320
if(ret == -1){
1321
perror("seteuid");
1322
}
1323
goto end;
1324
}
1325
}
1326
/* sleep checking until interface is running */
1327
for(int i=0; i < delay * 4; i++){
1328
ret = ioctl(sd, SIOCGIFFLAGS, &network);
1329
if(ret == -1){
1330
perror("ioctl SIOCGIFFLAGS");
1331
} else if(network.ifr_flags & IFF_RUNNING){
1332
break;
1333
}
1334
struct timespec sleeptime = { .tv_nsec = 250000000 };
1335
ret = nanosleep(&sleeptime, NULL);
1336
if(ret == -1 and errno != EINTR){
1337
perror("nanosleep");
1338
}
1339
}
1340
if(not take_down_interface){
1341
/* We won't need the socket anymore */
1342
ret = (int)TEMP_FAILURE_RETRY(close(sd));
1343
if(ret == -1){
1344
perror("close");
1345
}
1346
}
1347
#ifdef __linux__
1348
if(restore_loglevel){
1349
/* Restores kernel loglevel to default */
1350
ret = klogctl(7, NULL, 0);
1351
if(ret == -1){
1352
perror("klogctl");
1353
}
1354
}
1355
#endif /* __linux__ */
1356
/* Lower privileges */
1357
errno = 0;
1358
if(take_down_interface){
1359
/* Lower privileges */
1360
ret = seteuid(uid);
1361
if(ret == -1){
1362
perror("seteuid");
1363
}
1364
} else {
1365
/* Lower privileges permanently */
1366
ret = setuid(uid);
1367
if(ret == -1){
1368
perror("setuid");
1369
}
1370
}
1371
}
1372
1373
if(quit_now){
1374
goto end;
1375
}
1376
1377
ret = init_gnutls_global(pubkey, seckey);
1378
if(ret == -1){
1379
fprintf(stderr, "init_gnutls_global failed\n");
1380
exitcode = EXIT_FAILURE;
1381
goto end;
1382
} else {
1383
gnutls_initialized = true;
1384
}
1385
1386
if(quit_now){
1387
goto end;
1388
}
1389
1390
tempdir_created = true;
1391
if(mkdtemp(tempdir) == NULL){
1392
tempdir_created = false;
1393
perror("mkdtemp");
1394
goto end;
1395
}
1396
1397
if(quit_now){
1398
goto end;
1399
}
1400
1401
if(not init_gpgme(pubkey, seckey, tempdir)){
1402
fprintf(stderr, "init_gpgme failed\n");
1403
exitcode = EXIT_FAILURE;
1404
goto end;
1405
} else {
1406
gpgme_initialized = true;
1407
}
1408
1409
if(quit_now){
1410
goto end;
1411
}
1412
1413
if(connect_to != NULL){
1414
/* Connect directly, do not use Zeroconf */
1415
/* (Mainly meant for debugging) */
1416
char *address = strrchr(connect_to, ':');
1417
if(address == NULL){
1418
fprintf(stderr, "No colon in address\n");
1419
exitcode = EXIT_FAILURE;
1420
goto end;
1421
}
1422
1423
if(quit_now){
1424
goto end;
1425
}
1426
1427
uint16_t port;
1428
errno = 0;
1429
tmpmax = strtoimax(address+1, &tmp, 10);
1430
if(errno != 0 or tmp == address+1 or *tmp != '\0'
1431
or tmpmax != (uint16_t)tmpmax){
1432
fprintf(stderr, "Bad port number\n");
1433
exitcode = EXIT_FAILURE;
1434
goto end;
1435
}
1436
1437
if(quit_now){
1438
goto end;
1439
}
1440
1441
port = (uint16_t)tmpmax;
1442
*address = '\0';
1443
address = connect_to;
1444
/* Colon in address indicates IPv6 */
1445
int af;
1446
if(strchr(address, ':') != NULL){
1447
af = AF_INET6;
1448
} else {
1449
af = AF_INET;
1450
}
1451
1452
if(quit_now){
1453
goto end;
1454
}
1455
1456
ret = start_mandos_communication(address, port, if_index, af);
1457
if(ret < 0){
1458
exitcode = EXIT_FAILURE;
1459
} else {
1460
exitcode = EXIT_SUCCESS;
1461
}
1462
goto end;
1463
}
1464
1465
if(quit_now){
1466
goto end;
1467
}
1468
1469
{
1470
AvahiServerConfig config;
1471
/* Do not publish any local Zeroconf records */
1472
avahi_server_config_init(&config);
1473
config.publish_hinfo = 0;
1474
config.publish_addresses = 0;
1475
config.publish_workstation = 0;
1476
config.publish_domain = 0;
1477
1478
/* Allocate a new server */
1479
mc.server = avahi_server_new(avahi_simple_poll_get
1480
(mc.simple_poll), &config, NULL,
1481
NULL, &error);
1482
1483
/* Free the Avahi configuration data */
1484
avahi_server_config_free(&config);
1485
}
1486
1487
/* Check if creating the Avahi server object succeeded */
1488
if(mc.server == NULL){
1489
fprintf(stderr, "Failed to create Avahi server: %s\n",
1490
avahi_strerror(error));
1491
exitcode = EXIT_FAILURE;
1492
goto end;
1493
}
1494
1495
if(quit_now){
1496
goto end;
1497
}
1498
1499
/* Create the Avahi service browser */
1500
sb = avahi_s_service_browser_new(mc.server, if_index,
1501
AVAHI_PROTO_UNSPEC, "_mandos._tcp",
1502
NULL, 0, browse_callback, NULL);
1503
if(sb == NULL){
1504
fprintf(stderr, "Failed to create service browser: %s\n",
1505
avahi_strerror(avahi_server_errno(mc.server)));
1506
exitcode = EXIT_FAILURE;
1507
goto end;
1508
}
1509
1510
if(quit_now){
1511
goto end;
1512
}
1513
1514
/* Run the main loop */
1515
1516
if(debug){
1517
fprintf(stderr, "Starting Avahi loop search\n");
1518
}
1519
1520
avahi_simple_poll_loop(mc.simple_poll);
1521
988
exit(EXIT_FAILURE);
989
}
990
991
if(connect_to != NULL){
992
/* Connect directly, do not use Zeroconf */
993
/* (Mainly meant for debugging) */
994
char *address = strrchr(connect_to, ':');
995
if(address == NULL){
996
fprintf(stderr, "No colon in address\n");
997
exitcode = EXIT_FAILURE;
998
goto end;
999
}
1000
errno = 0;
1001
uint16_t port = (uint16_t) strtol(address+1, NULL, 10);
1002
if(errno){
1003
perror("Bad port number");
1004
exitcode = EXIT_FAILURE;
1005
goto end;
1006
}
1007
*address = '\0';
1008
address = connect_to;
1009
ret = start_mandos_communication(address, port, if_index, &mc);
1010
if(ret < 0){
1011
exitcode = EXIT_FAILURE;
1012
} else {
1013
exitcode = EXIT_SUCCESS;
1014
}
1015
goto end;
1016
}
1017
1018
if (not debug){
1019
avahi_set_log_function(empty_log);
1020
}
1021
1022
/* Initialize the pseudo-RNG for Avahi */
1023
srand((unsigned int) time(NULL));
1024
1025
/* Allocate main Avahi loop object */
1026
mc.simple_poll = avahi_simple_poll_new();
1027
if (mc.simple_poll == NULL) {
1028
fprintf(stderr, "Avahi: Failed to create simple poll"
1029
" object.\n");
1030
exitcode = EXIT_FAILURE;
1031
goto end;
1032
}
1033
1034
{
1035
AvahiServerConfig config;
1036
/* Do not publish any local Zeroconf records */
1037
avahi_server_config_init(&config);
1038
config.publish_hinfo = 0;
1039
config.publish_addresses = 0;
1040
config.publish_workstation = 0;
1041
config.publish_domain = 0;
1042
1043
/* Allocate a new server */
1044
mc.server = avahi_server_new(avahi_simple_poll_get
1045
(mc.simple_poll), &config, NULL,
1046
NULL, &error);
1047
1048
/* Free the Avahi configuration data */
1049
avahi_server_config_free(&config);
1050
}
1051
1052
/* Check if creating the Avahi server object succeeded */
1053
if (mc.server == NULL) {
1054
fprintf(stderr, "Failed to create Avahi server: %s\n",
1055
avahi_strerror(error));
1056
exitcode = EXIT_FAILURE;
1057
goto end;
1058
}
1059
1060
/* Create the Avahi service browser */
1061
sb = avahi_s_service_browser_new(mc.server, if_index,
1062
AVAHI_PROTO_INET6,
1063
"_mandos._tcp", NULL, 0,
1064
browse_callback, &mc);
1065
if (sb == NULL) {
1066
fprintf(stderr, "Failed to create service browser: %s\n",
1067
avahi_strerror(avahi_server_errno(mc.server)));
1068
exitcode = EXIT_FAILURE;
1069
goto end;
1070
}
1071
1072
/* Run the main loop */
1073
1074
if (debug){
1075
fprintf(stderr, "Starting Avahi loop search\n");
1076
}
1077
1078
avahi_simple_poll_loop(mc.simple_poll);
1079
1522
1080
end:
1523
1524
if(debug){
1525
fprintf(stderr, "%s exiting\n", argv[0]);
1526
}
1527
1528
/* Cleanup things */
1529
if(sb != NULL)
1530
avahi_s_service_browser_free(sb);
1531
1532
if(mc.server != NULL)
1533
avahi_server_free(mc.server);
1534
1535
if(mc.simple_poll != NULL)
1536
avahi_simple_poll_free(mc.simple_poll);
1537
1538
if(gnutls_initialized){
1539
gnutls_certificate_free_credentials(mc.cred);
1540
gnutls_global_deinit();
1541
gnutls_dh_params_deinit(mc.dh_params);
1542
}
1543
1544
if(gpgme_initialized){
1545
gpgme_release(mc.ctx);
1546
}
1547
1548
/* Take down the network interface */
1549
if(take_down_interface){
1550
/* Re-raise priviliges */
1551
errno = 0;
1552
ret = seteuid(0);
1553
if(ret == -1){
1554
perror("seteuid");
1555
}
1556
if(geteuid() == 0){
1557
ret = ioctl(sd, SIOCGIFFLAGS, &network);
1558
if(ret == -1){
1559
perror("ioctl SIOCGIFFLAGS");
1560
} else if(network.ifr_flags & IFF_UP) {
1561
network.ifr_flags &= ~IFF_UP; /* clear flag */
1562
ret = ioctl(sd, SIOCSIFFLAGS, &network);
1563
if(ret == -1){
1564
perror("ioctl SIOCSIFFLAGS");
1565
}
1566
}
1567
ret = (int)TEMP_FAILURE_RETRY(close(sd));
1568
if(ret == -1){
1569
perror("close");
1570
}
1571
/* Lower privileges permanently */
1572
errno = 0;
1573
ret = setuid(uid);
1574
if(ret == -1){
1575
perror("setuid");
1576
}
1577
}
1578
}
1579
1580
/* Removes the temp directory used by GPGME */
1581
if(tempdir_created){
1582
DIR *d;
1583
struct dirent *direntry;
1584
d = opendir(tempdir);
1585
if(d == NULL){
1586
if(errno != ENOENT){
1081
1082
if (debug){
1083
fprintf(stderr, "%s exiting\n", argv[0]);
1084
}
1085
1086
/* Cleanup things */
1087
if (sb != NULL)
1088
avahi_s_service_browser_free(sb);
1089
1090
if (mc.server != NULL)
1091
avahi_server_free(mc.server);
1092
1093
if (mc.simple_poll != NULL)
1094
avahi_simple_poll_free(mc.simple_poll);
1095
1096
if (gnutls_initalized){
1097
gnutls_certificate_free_credentials(mc.cred);
1098
gnutls_global_deinit ();
1099
gnutls_dh_params_deinit(mc.dh_params);
1100
}
1101
1102
if(gpgme_initalized){
1103
gpgme_release(mc.ctx);
1104
}
1105
1106
/* Removes the temp directory used by GPGME */
1107
if(tempdir[0] != '\0'){
1108
DIR *d;
1109
struct dirent *direntry;
1110
d = opendir(tempdir);
1111
if(d == NULL){
1587
1112
perror("opendir");
1588
}
1589
} else {
1590
while(true){
1591
direntry = readdir(d);
1592
if(direntry == NULL){
1593
break;
1594
}
1595
/* Skip "." and ".." */
1596
if(direntry->d_name[0] == '.'
1597
and (direntry->d_name[1] == '\0'
1598
or (direntry->d_name[1] == '.'
1599
and direntry->d_name[2] == '\0'))){
1600
continue;
1601
}
1602
char *fullname = NULL;
1603
ret = asprintf(&fullname, "%s/%s", tempdir,
1604
direntry->d_name);
1605
if(ret < 0){
1606
perror("asprintf");
1607
continue;
1608
}
1609
ret = remove(fullname);
1610
if(ret == -1){
1611
fprintf(stderr, "remove(\"%s\"): %s\n", fullname,
1612
strerror(errno));
1613
}
1614
free(fullname);
1615
}
1616
closedir(d);
1617
}
1618
ret = rmdir(tempdir);
1619
if(ret == -1 and errno != ENOENT){
1620
perror("rmdir");
1621
}
1622
}
1623
1624
if(quit_now){
1625
sigemptyset(&old_sigterm_action.sa_mask);
1626
old_sigterm_action.sa_handler = SIG_DFL;
1627
ret = sigaction(signal_received, &old_sigterm_action, NULL);
1628
if(ret == -1){
1629
perror("sigaction");
1630
}
1631
raise(signal_received);
1632
}
1633
1634
return exitcode;
1113
} else {
1114
while(true){
1115
direntry = readdir(d);
1116
if(direntry == NULL){
1117
break;
1118
}
1119
if (direntry->d_type == DT_REG){
1120
char *fullname = NULL;
1121
ret = asprintf(&fullname, "%s/%s", tempdir,
1122
direntry->d_name);
1123
if(ret < 0){
1124
perror("asprintf");
1125
continue;
1126
}
1127
ret = unlink(fullname);
1128
if(ret == -1){
1129
fprintf(stderr, "unlink(\"%s\"): %s",
1130
fullname, strerror(errno));
1131
}
1132
free(fullname);
1133
}
1134
}
1135
closedir(d);
1136
}
1137
ret = rmdir(tempdir);
1138
if(ret == -1){
1139
perror("rmdir");
1140
}
1141
}
1142
1143
return exitcode;
1635
1144
}
Loggerhead is a web-based interface for Breezy
Version: 2.0.2.dev0