47
110
#include <avahi-common/malloc.h>
48
111
#include <avahi-common/error.h>
51
#include <sys/types.h> /* socket(), inet_pton() */
52
#include <sys/socket.h> /* socket(), struct sockaddr_in6,
53
struct in6_addr, inet_pton() */
54
#include <gnutls/gnutls.h> /* All GnuTLS stuff */
55
#include <gnutls/openpgp.h> /* GnuTLS with openpgp stuff */
57
#include <unistd.h> /* close() */
58
#include <netinet/in.h>
59
#include <stdbool.h> /* true */
60
#include <string.h> /* memset */
61
#include <arpa/inet.h> /* inet_pton() */
62
#include <iso646.h> /* not */
65
#include <errno.h> /* perror() */
114
#include <gnutls/gnutls.h> /* All GnuTLS types, constants and
117
init_gnutls_session(),
119
#include <gnutls/openpgp.h>
120
/* gnutls_certificate_set_openpgp_key_file(),
121
GNUTLS_OPENPGP_FMT_BASE64 */
124
#include <gpgme.h> /* All GPGME types, constants and
127
GPGME_PROTOCOL_OpenPGP,
71
130
#define BUFFER_SIZE 256
74
const char *certdir = "/conf/conf.d/cryptkeyreq/";
75
const char *certfile = "openpgp-client.txt";
76
const char *certkey = "openpgp-client-key.txt";
132
#define PATHDIR "/conf/conf.d/mandos"
133
#define SECKEY "seckey.txt"
134
#define PUBKEY "pubkey.txt"
135
#define HOOKDIR "/lib/mandos/network-hooks.d"
78
137
bool debug = false;
138
static const char mandos_protocol_version[] = "1";
139
const char *argp_program_version = "mandos-client " VERSION;
140
const char *argp_program_bug_address = "<mandos@recompile.se>";
141
static const char sys_class_net[] = "/sys/class/net";
142
char *connect_to = NULL;
143
const char *hookdir = HOOKDIR;
147
/* Doubly linked list that need to be circularly linked when used */
148
typedef struct server{
151
AvahiIfIndex if_index;
153
struct timespec last_seen;
158
/* Used for passing in values through the Avahi callback functions */
81
gnutls_session_t session;
82
161
gnutls_certificate_credentials_t cred;
162
unsigned int dh_bits;
83
163
gnutls_dh_params_t dh_params;
87
ssize_t pgp_packet_decrypt (char *packet, size_t packet_size,
88
char **new_packet, const char *homedir){
89
gpgme_data_t dh_crypto, dh_plain;
164
const char *priority;
166
server *current_server;
168
size_t interfaces_size;
171
/* global so signal handler can reach it*/
172
AvahiSimplePoll *simple_poll;
174
sig_atomic_t quit_now = 0;
175
int signal_received = 0;
177
/* Function to use when printing errors */
178
void perror_plus(const char *print_text){
180
fprintf(stderr, "Mandos plugin %s: ",
181
program_invocation_short_name);
186
__attribute__((format (gnu_printf, 2, 3), nonnull))
187
int fprintf_plus(FILE *stream, const char *format, ...){
189
va_start (ap, format);
191
TEMP_FAILURE_RETRY(fprintf(stream, "Mandos plugin %s: ",
192
program_invocation_short_name));
193
return (int)TEMP_FAILURE_RETRY(vfprintf(stream, format, ap));
197
* Make additional room in "buffer" for at least BUFFER_SIZE more
198
* bytes. "buffer_capacity" is how much is currently allocated,
199
* "buffer_length" is how much is already used.
201
__attribute__((nonnull, warn_unused_result))
202
size_t incbuffer(char **buffer, size_t buffer_length,
203
size_t buffer_capacity){
204
if(buffer_length + BUFFER_SIZE > buffer_capacity){
205
char *new_buf = realloc(*buffer, buffer_capacity + BUFFER_SIZE);
207
int old_errno = errno;
214
buffer_capacity += BUFFER_SIZE;
216
return buffer_capacity;
219
/* Add server to set of servers to retry periodically */
220
__attribute__((nonnull, warn_unused_result))
221
bool add_server(const char *ip, in_port_t port, AvahiIfIndex if_index,
222
int af, server **current_server){
224
server *new_server = malloc(sizeof(server));
225
if(new_server == NULL){
226
perror_plus("malloc");
229
*new_server = (server){ .ip = strdup(ip),
231
.if_index = if_index,
233
if(new_server->ip == NULL){
234
perror_plus("strdup");
237
ret = clock_gettime(CLOCK_MONOTONIC, &(new_server->last_seen));
239
perror_plus("clock_gettime");
242
/* Special case of first server */
243
if(*current_server == NULL){
244
new_server->next = new_server;
245
new_server->prev = new_server;
246
*current_server = new_server;
248
/* Place the new server last in the list */
249
new_server->next = *current_server;
250
new_server->prev = (*current_server)->prev;
251
new_server->prev->next = new_server;
252
(*current_server)->prev = new_server;
260
__attribute__((nonnull, warn_unused_result))
261
static bool init_gpgme(const char *seckey, const char *pubkey,
262
const char *tempdir, mandos_context *mc){
93
ssize_t new_packet_capacity = 0;
94
ssize_t new_packet_length = 0;
95
264
gpgme_engine_info_t engine_info;
98
fprintf(stderr, "Trying to decrypt OpenPGP packet\n");
267
* Helper function to insert pub and seckey to the engine keyring.
269
bool import_key(const char *filename){
272
gpgme_data_t pgp_data;
274
fd = (int)TEMP_FAILURE_RETRY(open(filename, O_RDONLY));
280
rc = gpgme_data_new_from_fd(&pgp_data, fd);
281
if(rc != GPG_ERR_NO_ERROR){
282
fprintf_plus(stderr, "bad gpgme_data_new_from_fd: %s: %s\n",
283
gpgme_strsource(rc), gpgme_strerror(rc));
287
rc = gpgme_op_import(mc->ctx, pgp_data);
288
if(rc != GPG_ERR_NO_ERROR){
289
fprintf_plus(stderr, "bad gpgme_op_import: %s: %s\n",
290
gpgme_strsource(rc), gpgme_strerror(rc));
294
ret = (int)TEMP_FAILURE_RETRY(close(fd));
296
perror_plus("close");
298
gpgme_data_release(pgp_data);
303
fprintf_plus(stderr, "Initializing GPGME\n");
102
307
gpgme_check_version(NULL);
103
308
rc = gpgme_engine_check_version(GPGME_PROTOCOL_OpenPGP);
104
if (rc != GPG_ERR_NO_ERROR){
105
fprintf(stderr, "bad gpgme_engine_check_version: %s: %s\n",
106
gpgme_strsource(rc), gpgme_strerror(rc));
309
if(rc != GPG_ERR_NO_ERROR){
310
fprintf_plus(stderr, "bad gpgme_engine_check_version: %s: %s\n",
311
gpgme_strsource(rc), gpgme_strerror(rc));
110
/* Set GPGME home directory */
111
rc = gpgme_get_engine_info (&engine_info);
112
if (rc != GPG_ERR_NO_ERROR){
113
fprintf(stderr, "bad gpgme_get_engine_info: %s: %s\n",
114
gpgme_strsource(rc), gpgme_strerror(rc));
315
/* Set GPGME home directory for the OpenPGP engine only */
316
rc = gpgme_get_engine_info(&engine_info);
317
if(rc != GPG_ERR_NO_ERROR){
318
fprintf_plus(stderr, "bad gpgme_get_engine_info: %s: %s\n",
319
gpgme_strsource(rc), gpgme_strerror(rc));
117
322
while(engine_info != NULL){
118
323
if(engine_info->protocol == GPGME_PROTOCOL_OpenPGP){
119
324
gpgme_set_engine_info(GPGME_PROTOCOL_OpenPGP,
120
engine_info->file_name, homedir);
325
engine_info->file_name, tempdir);
123
328
engine_info = engine_info->next;
125
330
if(engine_info == NULL){
126
fprintf(stderr, "Could not set home dir to %s\n", homedir);
130
/* Create new GPGME data buffer from packet buffer */
131
rc = gpgme_data_new_from_mem(&dh_crypto, packet, packet_size, 0);
132
if (rc != GPG_ERR_NO_ERROR){
133
fprintf(stderr, "bad gpgme_data_new_from_mem: %s: %s\n",
134
gpgme_strsource(rc), gpgme_strerror(rc));
331
fprintf_plus(stderr, "Could not set GPGME home dir to %s\n",
336
/* Create new GPGME "context" */
337
rc = gpgme_new(&(mc->ctx));
338
if(rc != GPG_ERR_NO_ERROR){
339
fprintf_plus(stderr, "Mandos plugin mandos-client: "
340
"bad gpgme_new: %s: %s\n", gpgme_strsource(rc),
345
if(not import_key(pubkey) or not import_key(seckey)){
353
* Decrypt OpenPGP data.
354
* Returns -1 on error
356
__attribute__((nonnull, warn_unused_result))
357
static ssize_t pgp_packet_decrypt(const char *cryptotext,
361
gpgme_data_t dh_crypto, dh_plain;
364
size_t plaintext_capacity = 0;
365
ssize_t plaintext_length = 0;
368
fprintf_plus(stderr, "Trying to decrypt OpenPGP data\n");
371
/* Create new GPGME data buffer from memory cryptotext */
372
rc = gpgme_data_new_from_mem(&dh_crypto, cryptotext, crypto_size,
374
if(rc != GPG_ERR_NO_ERROR){
375
fprintf_plus(stderr, "bad gpgme_data_new_from_mem: %s: %s\n",
376
gpgme_strsource(rc), gpgme_strerror(rc));
138
380
/* Create new empty GPGME data buffer for the plaintext */
139
381
rc = gpgme_data_new(&dh_plain);
140
if (rc != GPG_ERR_NO_ERROR){
141
fprintf(stderr, "bad gpgme_data_new: %s: %s\n",
142
gpgme_strsource(rc), gpgme_strerror(rc));
146
/* Create new GPGME "context" */
147
rc = gpgme_new(&ctx);
148
if (rc != GPG_ERR_NO_ERROR){
149
fprintf(stderr, "bad gpgme_new: %s: %s\n",
150
gpgme_strsource(rc), gpgme_strerror(rc));
154
/* Decrypt data from the FILE pointer to the plaintext data
156
rc = gpgme_op_decrypt(ctx, dh_crypto, dh_plain);
157
if (rc != GPG_ERR_NO_ERROR){
158
fprintf(stderr, "bad gpgme_op_decrypt: %s: %s\n",
159
gpgme_strsource(rc), gpgme_strerror(rc));
164
fprintf(stderr, "Decryption of OpenPGP packet succeeded\n");
168
gpgme_decrypt_result_t result;
169
result = gpgme_op_decrypt_result(ctx);
171
fprintf(stderr, "gpgme_op_decrypt_result failed\n");
173
fprintf(stderr, "Unsupported algorithm: %s\n",
174
result->unsupported_algorithm);
175
fprintf(stderr, "Wrong key usage: %d\n",
176
result->wrong_key_usage);
177
if(result->file_name != NULL){
178
fprintf(stderr, "File name: %s\n", result->file_name);
180
gpgme_recipient_t recipient;
181
recipient = result->recipients;
382
if(rc != GPG_ERR_NO_ERROR){
383
fprintf_plus(stderr, "Mandos plugin mandos-client: "
384
"bad gpgme_data_new: %s: %s\n",
385
gpgme_strsource(rc), gpgme_strerror(rc));
386
gpgme_data_release(dh_crypto);
390
/* Decrypt data from the cryptotext data buffer to the plaintext
392
rc = gpgme_op_decrypt(mc->ctx, dh_crypto, dh_plain);
393
if(rc != GPG_ERR_NO_ERROR){
394
fprintf_plus(stderr, "bad gpgme_op_decrypt: %s: %s\n",
395
gpgme_strsource(rc), gpgme_strerror(rc));
396
plaintext_length = -1;
398
gpgme_decrypt_result_t result;
399
result = gpgme_op_decrypt_result(mc->ctx);
401
fprintf_plus(stderr, "gpgme_op_decrypt_result failed\n");
403
fprintf_plus(stderr, "Unsupported algorithm: %s\n",
404
result->unsupported_algorithm);
405
fprintf_plus(stderr, "Wrong key usage: %u\n",
406
result->wrong_key_usage);
407
if(result->file_name != NULL){
408
fprintf_plus(stderr, "File name: %s\n", result->file_name);
410
gpgme_recipient_t recipient;
411
recipient = result->recipients;
183
412
while(recipient != NULL){
184
fprintf(stderr, "Public key algorithm: %s\n",
185
gpgme_pubkey_algo_name(recipient->pubkey_algo));
186
fprintf(stderr, "Key ID: %s\n", recipient->keyid);
187
fprintf(stderr, "Secret key available: %s\n",
188
recipient->status == GPG_ERR_NO_SECKEY
413
fprintf_plus(stderr, "Public key algorithm: %s\n",
414
gpgme_pubkey_algo_name
415
(recipient->pubkey_algo));
416
fprintf_plus(stderr, "Key ID: %s\n", recipient->keyid);
417
fprintf_plus(stderr, "Secret key available: %s\n",
418
recipient->status == GPG_ERR_NO_SECKEY
190
420
recipient = recipient->next;
196
/* Delete the GPGME FILE pointer cryptotext data buffer */
197
gpgme_data_release(dh_crypto);
428
fprintf_plus(stderr, "Decryption of OpenPGP data succeeded\n");
199
431
/* Seek back to the beginning of the GPGME plaintext data buffer */
200
if (gpgme_data_seek(dh_plain, (off_t) 0, SEEK_SET) == -1){
201
perror("pgpme_data_seek");
432
if(gpgme_data_seek(dh_plain, (off_t)0, SEEK_SET) == -1){
433
perror_plus("gpgme_data_seek");
434
plaintext_length = -1;
206
if (new_packet_length + BUFFER_SIZE > new_packet_capacity){
207
*new_packet = realloc(*new_packet,
208
(unsigned int)new_packet_capacity
210
if (*new_packet == NULL){
214
new_packet_capacity += BUFFER_SIZE;
440
plaintext_capacity = incbuffer(plaintext,
441
(size_t)plaintext_length,
443
if(plaintext_capacity == 0){
444
perror_plus("incbuffer");
445
plaintext_length = -1;
217
ret = gpgme_data_read(dh_plain, *new_packet + new_packet_length,
449
ret = gpgme_data_read(dh_plain, *plaintext + plaintext_length,
219
451
/* Print the data, if any */
224
perror("gpgme_data_read");
227
new_packet_length += ret;
230
/* FIXME: check characters before printing to screen so to not print
231
terminal control characters */
233
/* fprintf(stderr, "decrypted password is: "); */
234
/* fwrite(*new_packet, 1, new_packet_length, stderr); */
235
/* fprintf(stderr, "\n"); */
457
perror_plus("gpgme_data_read");
458
plaintext_length = -1;
461
plaintext_length += ret;
465
fprintf_plus(stderr, "Decrypted password is: ");
466
for(ssize_t i = 0; i < plaintext_length; i++){
467
fprintf(stderr, "%02hhX ", (*plaintext)[i]);
469
fprintf(stderr, "\n");
474
/* Delete the GPGME cryptotext data buffer */
475
gpgme_data_release(dh_crypto);
238
477
/* Delete the GPGME plaintext data buffer */
239
478
gpgme_data_release(dh_plain);
240
return new_packet_length;
479
return plaintext_length;
243
static const char * safer_gnutls_strerror (int value) {
244
const char *ret = gnutls_strerror (value);
482
__attribute__((warn_unused_result))
483
static const char *safer_gnutls_strerror(int value){
484
const char *ret = gnutls_strerror(value);
246
486
ret = "(unknown)";
250
void debuggnutls(__attribute__((unused)) int level,
252
fprintf(stderr, "%s", string);
490
/* GnuTLS log function callback */
491
__attribute__((nonnull))
492
static void debuggnutls(__attribute__((unused)) int level,
494
fprintf_plus(stderr, "GnuTLS: %s", string);
255
int initgnutls(encrypted_session *es){
497
__attribute__((nonnull, warn_unused_result))
498
static int init_gnutls_global(const char *pubkeyfilename,
499
const char *seckeyfilename,
260
fprintf(stderr, "Initializing GnuTLS\n");
504
fprintf_plus(stderr, "Initializing GnuTLS\n");
263
if ((ret = gnutls_global_init ())
264
!= GNUTLS_E_SUCCESS) {
265
fprintf (stderr, "global_init: %s\n", safer_gnutls_strerror(ret));
507
ret = gnutls_global_init();
508
if(ret != GNUTLS_E_SUCCESS){
509
fprintf_plus(stderr, "GnuTLS global_init: %s\n",
510
safer_gnutls_strerror(ret));
515
/* "Use a log level over 10 to enable all debugging options."
270
518
gnutls_global_set_log_level(11);
271
519
gnutls_global_set_log_function(debuggnutls);
274
/* openpgp credentials */
275
if ((ret = gnutls_certificate_allocate_credentials (&es->cred))
276
!= GNUTLS_E_SUCCESS) {
277
fprintf (stderr, "memory error: %s\n",
278
safer_gnutls_strerror(ret));
522
/* OpenPGP credentials */
523
ret = gnutls_certificate_allocate_credentials(&mc->cred);
524
if(ret != GNUTLS_E_SUCCESS){
525
fprintf_plus(stderr, "GnuTLS memory error: %s\n",
526
safer_gnutls_strerror(ret));
527
gnutls_global_deinit();
283
fprintf(stderr, "Attempting to use OpenPGP certificate %s"
284
" and keyfile %s as GnuTLS credentials\n", certfile,
532
fprintf_plus(stderr, "Attempting to use OpenPGP public key %s and"
533
" secret key %s as GnuTLS credentials\n",
288
538
ret = gnutls_certificate_set_openpgp_key_file
289
(es->cred, certfile, certkey, GNUTLS_OPENPGP_FMT_BASE64);
290
if (ret != GNUTLS_E_SUCCESS) {
292
(stderr, "Error[%d] while reading the OpenPGP key pair ('%s',"
294
ret, certfile, certkey);
295
fprintf(stdout, "The Error is: %s\n",
296
safer_gnutls_strerror(ret));
300
//GnuTLS server initialization
301
if ((ret = gnutls_dh_params_init (&es->dh_params))
302
!= GNUTLS_E_SUCCESS) {
303
fprintf (stderr, "Error in dh parameter initialization: %s\n",
304
safer_gnutls_strerror(ret));
308
if ((ret = gnutls_dh_params_generate2 (es->dh_params, DH_BITS))
309
!= GNUTLS_E_SUCCESS) {
310
fprintf (stderr, "Error in prime generation: %s\n",
311
safer_gnutls_strerror(ret));
315
gnutls_certificate_set_dh_params (es->cred, es->dh_params);
317
// GnuTLS session creation
318
if ((ret = gnutls_init (&es->session, GNUTLS_SERVER))
319
!= GNUTLS_E_SUCCESS){
320
fprintf(stderr, "Error in GnuTLS session initialization: %s\n",
321
safer_gnutls_strerror(ret));
324
if ((ret = gnutls_priority_set_direct (es->session, "NORMAL", &err))
325
!= GNUTLS_E_SUCCESS) {
326
fprintf(stderr, "Syntax error at: %s\n", err);
327
fprintf(stderr, "GnuTLS error: %s\n",
328
safer_gnutls_strerror(ret));
332
if ((ret = gnutls_credentials_set
333
(es->session, GNUTLS_CRD_CERTIFICATE, es->cred))
334
!= GNUTLS_E_SUCCESS) {
335
fprintf(stderr, "Error setting a credentials set: %s\n",
336
safer_gnutls_strerror(ret));
539
(mc->cred, pubkeyfilename, seckeyfilename,
540
GNUTLS_OPENPGP_FMT_BASE64);
541
if(ret != GNUTLS_E_SUCCESS){
543
"Error[%d] while reading the OpenPGP key pair ('%s',"
544
" '%s')\n", ret, pubkeyfilename, seckeyfilename);
545
fprintf_plus(stderr, "The GnuTLS error is: %s\n",
546
safer_gnutls_strerror(ret));
550
/* GnuTLS server initialization */
551
ret = gnutls_dh_params_init(&mc->dh_params);
552
if(ret != GNUTLS_E_SUCCESS){
553
fprintf_plus(stderr, "Error in GnuTLS DH parameter"
554
" initialization: %s\n",
555
safer_gnutls_strerror(ret));
558
ret = gnutls_dh_params_generate2(mc->dh_params, mc->dh_bits);
559
if(ret != GNUTLS_E_SUCCESS){
560
fprintf_plus(stderr, "Error in GnuTLS prime generation: %s\n",
561
safer_gnutls_strerror(ret));
565
gnutls_certificate_set_dh_params(mc->cred, mc->dh_params);
571
gnutls_certificate_free_credentials(mc->cred);
572
gnutls_global_deinit();
573
gnutls_dh_params_deinit(mc->dh_params);
577
__attribute__((nonnull, warn_unused_result))
578
static int init_gnutls_session(gnutls_session_t *session,
581
/* GnuTLS session creation */
583
ret = gnutls_init(session, GNUTLS_SERVER);
587
} while(ret == GNUTLS_E_INTERRUPTED or ret == GNUTLS_E_AGAIN);
588
if(ret != GNUTLS_E_SUCCESS){
590
"Error in GnuTLS session initialization: %s\n",
591
safer_gnutls_strerror(ret));
597
ret = gnutls_priority_set_direct(*session, mc->priority, &err);
599
gnutls_deinit(*session);
602
} while(ret == GNUTLS_E_INTERRUPTED or ret == GNUTLS_E_AGAIN);
603
if(ret != GNUTLS_E_SUCCESS){
604
fprintf_plus(stderr, "Syntax error at: %s\n", err);
605
fprintf_plus(stderr, "GnuTLS error: %s\n",
606
safer_gnutls_strerror(ret));
607
gnutls_deinit(*session);
613
ret = gnutls_credentials_set(*session, GNUTLS_CRD_CERTIFICATE,
616
gnutls_deinit(*session);
619
} while(ret == GNUTLS_E_INTERRUPTED or ret == GNUTLS_E_AGAIN);
620
if(ret != GNUTLS_E_SUCCESS){
621
fprintf_plus(stderr, "Error setting GnuTLS credentials: %s\n",
622
safer_gnutls_strerror(ret));
623
gnutls_deinit(*session);
340
627
/* ignore client certificate if any. */
341
gnutls_certificate_server_set_request (es->session,
628
gnutls_certificate_server_set_request(*session, GNUTLS_CERT_IGNORE);
344
gnutls_dh_set_prime_bits (es->session, DH_BITS);
630
gnutls_dh_set_prime_bits(*session, mc->dh_bits);
349
void empty_log(__attribute__((unused)) AvahiLogLevel level,
350
__attribute__((unused)) const char *txt){}
635
/* Avahi log function callback */
636
static void empty_log(__attribute__((unused)) AvahiLogLevel level,
637
__attribute__((unused)) const char *txt){}
352
int start_mandos_communication(const char *ip, uint16_t port,
353
unsigned int if_index){
355
struct sockaddr_in6 to;
356
encrypted_session es;
639
/* Called when a Mandos server is found */
640
__attribute__((nonnull, warn_unused_result))
641
static int start_mandos_communication(const char *ip, in_port_t port,
642
AvahiIfIndex if_index,
643
int af, mandos_context *mc){
644
int ret, tcp_sd = -1;
646
struct sockaddr_storage to;
357
647
char *buffer = NULL;
358
char *decrypted_buffer;
648
char *decrypted_buffer = NULL;
359
649
size_t buffer_length = 0;
360
650
size_t buffer_capacity = 0;
361
ssize_t decrypted_buffer_size;
364
char interface[IF_NAMESIZE];
367
fprintf(stderr, "Setting up a tcp connection to %s\n", ip);
370
tcp_sd = socket(PF_INET6, SOCK_STREAM, 0);
376
if(if_indextoname(if_index, interface) == NULL){
378
perror("if_indextoname");
384
fprintf(stderr, "Binding to interface %s\n", interface);
387
memset(&to,0,sizeof(to)); /* Spurious warning */
388
to.sin6_family = AF_INET6;
389
ret = inet_pton(AF_INET6, ip, &to.sin6_addr);
653
gnutls_session_t session;
654
int pf; /* Protocol family */
671
fprintf_plus(stderr, "Bad address family: %d\n", af);
676
/* If the interface is specified and we have a list of interfaces */
677
if(if_index != AVAHI_IF_UNSPEC and mc->interfaces != NULL){
678
/* Check if the interface is one of the interfaces we are using */
681
char *interface = NULL;
682
while((interface=argz_next(mc->interfaces, mc->interfaces_size,
684
if(if_nametoindex(interface) == (unsigned int)if_index){
691
/* This interface does not match any in the list, so we don't
692
connect to the server */
694
char interface[IF_NAMESIZE];
695
if(if_indextoname((unsigned int)if_index, interface) == NULL){
696
perror_plus("if_indextoname");
698
fprintf_plus(stderr, "Skipping server on non-used interface"
700
if_indextoname((unsigned int)if_index,
708
ret = init_gnutls_session(&session, mc);
714
fprintf_plus(stderr, "Setting up a TCP connection to %s, port %"
715
PRIuMAX "\n", ip, (uintmax_t)port);
718
tcp_sd = socket(pf, SOCK_STREAM, 0);
721
perror_plus("socket");
731
memset(&to, 0, sizeof(to));
733
((struct sockaddr_in6 *)&to)->sin6_family = (sa_family_t)af;
734
ret = inet_pton(af, ip, &((struct sockaddr_in6 *)&to)->sin6_addr);
736
((struct sockaddr_in *)&to)->sin_family = (sa_family_t)af;
737
ret = inet_pton(af, ip, &((struct sockaddr_in *)&to)->sin_addr);
741
perror_plus("inet_pton");
395
fprintf(stderr, "Bad address: %s\n", ip);
398
to.sin6_port = htons(port); /* Spurious warning */
400
to.sin6_scope_id = (uint32_t)if_index;
403
fprintf(stderr, "Connection to: %s\n", ip);
406
ret = connect(tcp_sd, (struct sockaddr *) &to, sizeof(to));
412
ret = initgnutls (&es);
418
gnutls_transport_set_ptr (es.session,
419
(gnutls_transport_ptr_t) tcp_sd);
422
fprintf(stderr, "Establishing TLS session with %s\n", ip);
425
ret = gnutls_handshake (es.session);
427
if (ret != GNUTLS_E_SUCCESS){
747
fprintf_plus(stderr, "Bad address: %s\n", ip);
752
((struct sockaddr_in6 *)&to)->sin6_port = htons(port);
753
if(IN6_IS_ADDR_LINKLOCAL
754
(&((struct sockaddr_in6 *)&to)->sin6_addr)){
755
if(if_index == AVAHI_IF_UNSPEC){
756
fprintf_plus(stderr, "An IPv6 link-local address is"
757
" incomplete without a network interface\n");
761
/* Set the network interface number as scope */
762
((struct sockaddr_in6 *)&to)->sin6_scope_id = (uint32_t)if_index;
765
((struct sockaddr_in *)&to)->sin_port = htons(port);
774
if(af == AF_INET6 and if_index != AVAHI_IF_UNSPEC){
775
char interface[IF_NAMESIZE];
776
if(if_indextoname((unsigned int)if_index, interface) == NULL){
777
perror_plus("if_indextoname");
779
fprintf_plus(stderr, "Connection to: %s%%%s, port %" PRIuMAX
780
"\n", ip, interface, (uintmax_t)port);
783
fprintf_plus(stderr, "Connection to: %s, port %" PRIuMAX "\n",
784
ip, (uintmax_t)port);
786
char addrstr[(INET_ADDRSTRLEN > INET6_ADDRSTRLEN) ?
787
INET_ADDRSTRLEN : INET6_ADDRSTRLEN] = "";
789
ret = getnameinfo((struct sockaddr *)&to,
790
sizeof(struct sockaddr_in6),
791
addrstr, sizeof(addrstr), NULL, 0,
794
ret = getnameinfo((struct sockaddr *)&to,
795
sizeof(struct sockaddr_in),
796
addrstr, sizeof(addrstr), NULL, 0,
799
if(ret == EAI_SYSTEM){
800
perror_plus("getnameinfo");
801
} else if(ret != 0) {
802
fprintf_plus(stderr, "getnameinfo: %s", gai_strerror(ret));
803
} else if(strcmp(addrstr, ip) != 0){
804
fprintf_plus(stderr, "Canonical address form: %s\n", addrstr);
814
ret = connect(tcp_sd, (struct sockaddr *)&to,
815
sizeof(struct sockaddr_in6));
817
ret = connect(tcp_sd, (struct sockaddr *)&to, /* IPv4 */
818
sizeof(struct sockaddr_in));
821
if((errno != ECONNREFUSED and errno != ENETUNREACH) or debug){
823
perror_plus("connect");
834
const char *out = mandos_protocol_version;
837
size_t out_size = strlen(out);
838
ret = (int)TEMP_FAILURE_RETRY(write(tcp_sd, out + written,
839
out_size - written));
842
perror_plus("write");
846
written += (size_t)ret;
847
if(written < out_size){
850
if(out == mandos_protocol_version){
865
fprintf_plus(stderr, "Establishing TLS session with %s\n", ip);
873
/* This casting via intptr_t is to eliminate warning about casting
874
an int to a pointer type. This is exactly how the GnuTLS Guile
875
function "set-session-transport-fd!" does it. */
876
gnutls_transport_set_ptr(session,
877
(gnutls_transport_ptr_t)(intptr_t)tcp_sd);
885
ret = gnutls_handshake(session);
890
} while(ret == GNUTLS_E_AGAIN or ret == GNUTLS_E_INTERRUPTED);
892
if(ret != GNUTLS_E_SUCCESS){
429
fprintf(stderr, "\n*** Handshake failed ***\n");
894
fprintf_plus(stderr, "*** GnuTLS Handshake failed ***\n");
436
//Retrieve OpenPGP packet that contains the wanted password
901
/* Read OpenPGP packet that contains the wanted password */
439
fprintf(stderr, "Retrieving pgp encrypted password from %s\n",
904
fprintf_plus(stderr, "Retrieving OpenPGP encrypted password from"
444
if (buffer_length + BUFFER_SIZE > buffer_capacity){
445
buffer = realloc(buffer, buffer_capacity + BUFFER_SIZE);
450
buffer_capacity += BUFFER_SIZE;
453
ret = gnutls_record_recv
454
(es.session, buffer+buffer_length, BUFFER_SIZE);
915
buffer_capacity = incbuffer(&buffer, buffer_length,
917
if(buffer_capacity == 0){
919
perror_plus("incbuffer");
929
sret = gnutls_record_recv(session, buffer+buffer_length,
460
936
case GNUTLS_E_INTERRUPTED:
461
937
case GNUTLS_E_AGAIN:
463
939
case GNUTLS_E_REHANDSHAKE:
464
ret = gnutls_handshake (es.session);
466
fprintf(stderr, "\n*** Handshake failed ***\n");
941
ret = gnutls_handshake(session);
947
} while(ret == GNUTLS_E_AGAIN or ret == GNUTLS_E_INTERRUPTED);
949
fprintf_plus(stderr, "*** GnuTLS Re-handshake failed "
473
fprintf(stderr, "Unknown error while reading data from"
474
" encrypted session with mandos server\n");
476
gnutls_bye (es.session, GNUTLS_SHUT_RDWR);
957
fprintf_plus(stderr, "Unknown error while reading data from"
958
" encrypted session with Mandos server\n");
959
gnutls_bye(session, GNUTLS_SHUT_RDWR);
480
buffer_length += (size_t) ret;
484
if (buffer_length > 0){
485
decrypted_buffer_size = pgp_packet_decrypt(buffer,
489
if (decrypted_buffer_size >= 0){
490
while(written < decrypted_buffer_size){
491
ret = (int)fwrite (decrypted_buffer + written, 1,
492
(size_t)decrypted_buffer_size - written,
964
buffer_length += (size_t) sret;
969
fprintf_plus(stderr, "Closing TLS session\n");
978
ret = gnutls_bye(session, GNUTLS_SHUT_RDWR);
983
} while(ret == GNUTLS_E_AGAIN or ret == GNUTLS_E_INTERRUPTED);
985
if(buffer_length > 0){
986
ssize_t decrypted_buffer_size;
987
decrypted_buffer_size = pgp_packet_decrypt(buffer, buffer_length,
988
&decrypted_buffer, mc);
989
if(decrypted_buffer_size >= 0){
992
while(written < (size_t) decrypted_buffer_size){
998
ret = (int)fwrite(decrypted_buffer + written, 1,
999
(size_t)decrypted_buffer_size - written,
494
1001
if(ret == 0 and ferror(stdout)){
496
fprintf(stderr, "Error writing encrypted data: %s\n",
1004
fprintf_plus(stderr, "Error writing encrypted data: %s\n",
502
1010
written += (size_t)ret;
504
free(decrypted_buffer);
1016
/* Shutdown procedure */
1021
free(decrypted_buffer);
1024
ret = (int)TEMP_FAILURE_RETRY(close(tcp_sd));
1030
perror_plus("close");
1032
gnutls_deinit(session);
513
fprintf(stderr, "Closing TLS session\n");
517
gnutls_bye (es.session, GNUTLS_SHUT_RDWR);
520
gnutls_deinit (es.session);
521
gnutls_certificate_free_credentials (es.cred);
522
gnutls_global_deinit ();
526
static AvahiSimplePoll *simple_poll = NULL;
527
static AvahiServer *server = NULL;
529
static void resolve_callback(
530
AvahiSServiceResolver *r,
531
AvahiIfIndex interface,
532
AVAHI_GCC_UNUSED AvahiProtocol protocol,
533
AvahiResolverEvent event,
537
const char *host_name,
538
const AvahiAddress *address,
540
AVAHI_GCC_UNUSED AvahiStringList *txt,
541
AVAHI_GCC_UNUSED AvahiLookupResultFlags flags,
542
AVAHI_GCC_UNUSED void* userdata) {
544
assert(r); /* Spurious warning */
1042
__attribute__((nonnull))
1043
static void resolve_callback(AvahiSServiceResolver *r,
1044
AvahiIfIndex interface,
1045
AvahiProtocol proto,
1046
AvahiResolverEvent event,
1050
const char *host_name,
1051
const AvahiAddress *address,
1053
AVAHI_GCC_UNUSED AvahiStringList *txt,
1054
AVAHI_GCC_UNUSED AvahiLookupResultFlags
546
1061
/* Called whenever a service has been resolved successfully or
551
1070
case AVAHI_RESOLVER_FAILURE:
552
fprintf(stderr, "(Resolver) Failed to resolve service '%s' of"
553
" type '%s' in domain '%s': %s\n", name, type, domain,
554
avahi_strerror(avahi_server_errno(server)));
1071
fprintf_plus(stderr, "(Avahi Resolver) Failed to resolve service "
1072
"'%s' of type '%s' in domain '%s': %s\n", name, type,
1074
avahi_strerror(avahi_server_errno
1075
(((mandos_context*)mc)->server)));
557
1078
case AVAHI_RESOLVER_FOUND:
559
1080
char ip[AVAHI_ADDRESS_STR_MAX];
560
1081
avahi_address_snprint(ip, sizeof(ip), address);
562
fprintf(stderr, "Mandos server \"%s\" found on %s (%s) on"
563
" port %d\n", name, host_name, ip, port);
1083
fprintf_plus(stderr, "Mandos server \"%s\" found on %s (%s, %"
1084
PRIdMAX ") on port %" PRIu16 "\n", name,
1085
host_name, ip, (intmax_t)interface, port);
565
int ret = start_mandos_communication(ip, port,
566
(unsigned int) interface);
1087
int ret = start_mandos_communication(ip, (in_port_t)port,
1089
avahi_proto_to_af(proto),
1092
avahi_simple_poll_quit(simple_poll);
1094
if(not add_server(ip, (in_port_t)port, interface,
1095
avahi_proto_to_af(proto),
1096
&((mandos_context*)mc)->current_server)){
1097
fprintf_plus(stderr, "Failed to add server \"%s\" to server"
572
1103
avahi_s_service_resolver_free(r);
575
static void browse_callback(
576
AvahiSServiceBrowser *b,
577
AvahiIfIndex interface,
578
AvahiProtocol protocol,
579
AvahiBrowserEvent event,
583
AVAHI_GCC_UNUSED AvahiLookupResultFlags flags,
586
AvahiServer *s = userdata;
587
assert(b); /* Spurious warning */
589
/* Called whenever a new services becomes available on the LAN or
590
is removed from the LAN */
1106
static void browse_callback(AvahiSServiceBrowser *b,
1107
AvahiIfIndex interface,
1108
AvahiProtocol protocol,
1109
AvahiBrowserEvent event,
1113
AVAHI_GCC_UNUSED AvahiLookupResultFlags
1120
/* Called whenever a new services becomes available on the LAN or
1121
is removed from the LAN */
1129
case AVAHI_BROWSER_FAILURE:
1131
fprintf_plus(stderr, "(Avahi browser) %s\n",
1132
avahi_strerror(avahi_server_errno
1133
(((mandos_context*)mc)->server)));
1134
avahi_simple_poll_quit(simple_poll);
1137
case AVAHI_BROWSER_NEW:
1138
/* We ignore the returned Avahi resolver object. In the callback
1139
function we free it. If the Avahi server is terminated before
1140
the callback function is called the Avahi server will free the
1143
if(avahi_s_service_resolver_new(((mandos_context*)mc)->server,
1144
interface, protocol, name, type,
1145
domain, protocol, 0,
1146
resolve_callback, mc) == NULL)
1147
fprintf_plus(stderr, "Avahi: Failed to resolve service '%s':"
1149
avahi_strerror(avahi_server_errno
1150
(((mandos_context*)mc)->server)));
1153
case AVAHI_BROWSER_REMOVE:
1156
case AVAHI_BROWSER_ALL_FOR_NOW:
1157
case AVAHI_BROWSER_CACHE_EXHAUSTED:
1159
fprintf_plus(stderr, "No Mandos server found, still"
1166
/* Signal handler that stops main loop after SIGTERM */
1167
static void handle_sigterm(int sig){
1172
signal_received = sig;
1173
int old_errno = errno;
1174
/* set main loop to exit */
1175
if(simple_poll != NULL){
1176
avahi_simple_poll_quit(simple_poll);
1181
__attribute__((nonnull, warn_unused_result))
1182
bool get_flags(const char *ifname, struct ifreq *ifr){
1186
int s = socket(PF_INET6, SOCK_DGRAM, IPPROTO_IP);
1189
perror_plus("socket");
1193
strcpy(ifr->ifr_name, ifname);
1194
ret = ioctl(s, SIOCGIFFLAGS, ifr);
1198
perror_plus("ioctl SIOCGIFFLAGS");
1206
__attribute__((nonnull, warn_unused_result))
1207
bool good_flags(const char *ifname, const struct ifreq *ifr){
1209
/* Reject the loopback device */
1210
if(ifr->ifr_flags & IFF_LOOPBACK){
1212
fprintf_plus(stderr, "Rejecting loopback interface \"%s\"\n",
1217
/* Accept point-to-point devices only if connect_to is specified */
1218
if(connect_to != NULL and (ifr->ifr_flags & IFF_POINTOPOINT)){
1220
fprintf_plus(stderr, "Accepting point-to-point interface"
1221
" \"%s\"\n", ifname);
1225
/* Otherwise, reject non-broadcast-capable devices */
1226
if(not (ifr->ifr_flags & IFF_BROADCAST)){
1228
fprintf_plus(stderr, "Rejecting non-broadcast interface"
1229
" \"%s\"\n", ifname);
1233
/* Reject non-ARP interfaces (including dummy interfaces) */
1234
if(ifr->ifr_flags & IFF_NOARP){
1236
fprintf_plus(stderr, "Rejecting non-ARP interface \"%s\"\n",
1242
/* Accept this device */
1244
fprintf_plus(stderr, "Interface \"%s\" is good\n", ifname);
1250
* This function determines if a directory entry in /sys/class/net
1251
* corresponds to an acceptable network device.
1252
* (This function is passed to scandir(3) as a filter function.)
1254
__attribute__((nonnull, warn_unused_result))
1255
int good_interface(const struct dirent *if_entry){
1256
if(if_entry->d_name[0] == '.'){
1261
if(not get_flags(if_entry->d_name, &ifr)){
1263
fprintf_plus(stderr, "Failed to get flags for interface "
1264
"\"%s\"\n", if_entry->d_name);
1269
if(not good_flags(if_entry->d_name, &ifr)){
1276
* This function determines if a network interface is up.
1278
__attribute__((nonnull, warn_unused_result))
1279
bool interface_is_up(const char *interface){
1281
if(not get_flags(interface, &ifr)){
1283
fprintf_plus(stderr, "Failed to get flags for interface "
1284
"\"%s\"\n", interface);
1289
return (bool)(ifr.ifr_flags & IFF_UP);
1293
* This function determines if a network interface is running
1295
__attribute__((nonnull, warn_unused_result))
1296
bool interface_is_running(const char *interface){
1298
if(not get_flags(interface, &ifr)){
1300
fprintf_plus(stderr, "Failed to get flags for interface "
1301
"\"%s\"\n", interface);
1306
return (bool)(ifr.ifr_flags & IFF_RUNNING);
1309
__attribute__((nonnull, pure, warn_unused_result))
1310
int notdotentries(const struct dirent *direntry){
1311
/* Skip "." and ".." */
1312
if(direntry->d_name[0] == '.'
1313
and (direntry->d_name[1] == '\0'
1314
or (direntry->d_name[1] == '.'
1315
and direntry->d_name[2] == '\0'))){
1321
/* Is this directory entry a runnable program? */
1322
__attribute__((nonnull, warn_unused_result))
1323
int runnable_hook(const struct dirent *direntry){
1328
if((direntry->d_name)[0] == '\0'){
1333
sret = strspn(direntry->d_name, "ABCDEFGHIJKLMNOPQRSTUVWXYZ"
1334
"abcdefghijklmnopqrstuvwxyz"
1337
if((direntry->d_name)[sret] != '\0'){
1338
/* Contains non-allowed characters */
1340
fprintf_plus(stderr, "Ignoring hook \"%s\" with bad name\n",
1346
char *fullname = NULL;
1347
ret = asprintf(&fullname, "%s/%s", hookdir, direntry->d_name);
1349
perror_plus("asprintf");
1353
ret = stat(fullname, &st);
1356
perror_plus("Could not stat hook");
1360
if(not (S_ISREG(st.st_mode))){
1361
/* Not a regular file */
1363
fprintf_plus(stderr, "Ignoring hook \"%s\" - not a file\n",
1368
if(not (st.st_mode & (S_IXUSR | S_IXGRP | S_IXOTH))){
1369
/* Not executable */
1371
fprintf_plus(stderr, "Ignoring hook \"%s\" - not executable\n",
1377
fprintf_plus(stderr, "Hook \"%s\" is acceptable\n",
1383
__attribute__((nonnull, warn_unused_result))
1384
int avahi_loop_with_timeout(AvahiSimplePoll *s, int retry_interval,
1385
mandos_context *mc){
1387
struct timespec now;
1388
struct timespec waited_time;
1389
intmax_t block_time;
1392
if(mc->current_server == NULL){
1394
fprintf_plus(stderr, "Wait until first server is found."
1397
ret = avahi_simple_poll_iterate(s, -1);
1400
fprintf_plus(stderr, "Check current_server if we should run"
1403
/* the current time */
1404
ret = clock_gettime(CLOCK_MONOTONIC, &now);
1406
perror_plus("clock_gettime");
1409
/* Calculating in ms how long time between now and server
1410
who we visted longest time ago. Now - last seen. */
1411
waited_time.tv_sec = (now.tv_sec
1412
- mc->current_server->last_seen.tv_sec);
1413
waited_time.tv_nsec = (now.tv_nsec
1414
- mc->current_server->last_seen.tv_nsec);
1415
/* total time is 10s/10,000ms.
1416
Converting to s from ms by dividing by 1,000,
1417
and ns to ms by dividing by 1,000,000. */
1418
block_time = ((retry_interval
1419
- ((intmax_t)waited_time.tv_sec * 1000))
1420
- ((intmax_t)waited_time.tv_nsec / 1000000));
1423
fprintf_plus(stderr, "Blocking for %" PRIdMAX " ms\n",
1427
if(block_time <= 0){
1428
ret = start_mandos_communication(mc->current_server->ip,
1429
mc->current_server->port,
1430
mc->current_server->if_index,
1431
mc->current_server->af, mc);
1433
avahi_simple_poll_quit(s);
1436
ret = clock_gettime(CLOCK_MONOTONIC,
1437
&mc->current_server->last_seen);
1439
perror_plus("clock_gettime");
1442
mc->current_server = mc->current_server->next;
1443
block_time = 0; /* Call avahi to find new Mandos
1444
servers, but don't block */
1447
ret = avahi_simple_poll_iterate(s, (int)block_time);
1450
if(ret > 0 or errno != EINTR){
1451
return (ret != 1) ? ret : 0;
1457
/* Set effective uid to 0, return errno */
1458
__attribute__((warn_unused_result))
1459
error_t raise_privileges(void){
1460
error_t old_errno = errno;
1461
error_t ret_errno = 0;
1462
if(seteuid(0) == -1){
1464
perror_plus("seteuid");
1470
/* Set effective and real user ID to 0. Return errno. */
1471
__attribute__((warn_unused_result))
1472
error_t raise_privileges_permanently(void){
1473
error_t old_errno = errno;
1474
error_t ret_errno = raise_privileges();
1479
if(setuid(0) == -1){
1481
perror_plus("seteuid");
1487
/* Set effective user ID to unprivileged saved user ID */
1488
__attribute__((warn_unused_result))
1489
error_t lower_privileges(void){
1490
error_t old_errno = errno;
1491
error_t ret_errno = 0;
1492
if(seteuid(uid) == -1){
1494
perror_plus("seteuid");
1500
/* Lower privileges permanently */
1501
__attribute__((warn_unused_result))
1502
error_t lower_privileges_permanently(void){
1503
error_t old_errno = errno;
1504
error_t ret_errno = 0;
1505
if(setuid(uid) == -1){
1507
perror_plus("setuid");
1513
__attribute__((nonnull))
1514
void run_network_hooks(const char *mode, const char *interface,
1516
struct dirent **direntries;
1517
int numhooks = scandir(hookdir, &direntries, runnable_hook,
1520
if(errno == ENOENT){
1522
fprintf_plus(stderr, "Network hook directory \"%s\" not"
1523
" found\n", hookdir);
1526
perror_plus("scandir");
1529
struct dirent *direntry;
1531
int devnull = open("/dev/null", O_RDONLY);
1532
for(int i = 0; i < numhooks; i++){
1533
direntry = direntries[i];
1534
char *fullname = NULL;
1535
ret = asprintf(&fullname, "%s/%s", hookdir, direntry->d_name);
1537
perror_plus("asprintf");
1541
fprintf_plus(stderr, "Running network hook \"%s\"\n",
1544
pid_t hook_pid = fork();
1547
/* Raise privileges */
1548
if(raise_privileges_permanently() != 0){
1549
perror_plus("Failed to raise privileges");
1556
perror_plus("setgid");
1559
/* Reset supplementary groups */
1561
ret = setgroups(0, NULL);
1563
perror_plus("setgroups");
1566
ret = dup2(devnull, STDIN_FILENO);
1568
perror_plus("dup2(devnull, STDIN_FILENO)");
1571
ret = close(devnull);
1573
perror_plus("close");
1576
ret = dup2(STDERR_FILENO, STDOUT_FILENO);
1578
perror_plus("dup2(STDERR_FILENO, STDOUT_FILENO)");
1581
ret = setenv("MANDOSNETHOOKDIR", hookdir, 1);
1583
perror_plus("setenv");
1586
ret = setenv("DEVICE", interface, 1);
1588
perror_plus("setenv");
1591
ret = setenv("VERBOSITY", debug ? "1" : "0", 1);
1593
perror_plus("setenv");
1596
ret = setenv("MODE", mode, 1);
1598
perror_plus("setenv");
1602
ret = asprintf(&delaystring, "%f", (double)delay);
1604
perror_plus("asprintf");
1607
ret = setenv("DELAY", delaystring, 1);
1610
perror_plus("setenv");
1614
if(connect_to != NULL){
1615
ret = setenv("CONNECT", connect_to, 1);
1617
perror_plus("setenv");
1621
if(execl(fullname, direntry->d_name, mode, NULL) == -1){
1622
perror_plus("execl");
1623
_exit(EXIT_FAILURE);
1627
if(TEMP_FAILURE_RETRY(waitpid(hook_pid, &status, 0)) == -1){
1628
perror_plus("waitpid");
1632
if(WIFEXITED(status)){
1633
if(WEXITSTATUS(status) != 0){
1634
fprintf_plus(stderr, "Warning: network hook \"%s\" exited"
1635
" with status %d\n", direntry->d_name,
1636
WEXITSTATUS(status));
1640
} else if(WIFSIGNALED(status)){
1641
fprintf_plus(stderr, "Warning: network hook \"%s\" died by"
1642
" signal %d\n", direntry->d_name,
1647
fprintf_plus(stderr, "Warning: network hook \"%s\""
1648
" crashed\n", direntry->d_name);
1655
fprintf_plus(stderr, "Network hook \"%s\" ran successfully\n",
1663
__attribute__((nonnull, warn_unused_result))
1664
error_t bring_up_interface(const char *const interface,
1666
error_t old_errno = errno;
1668
struct ifreq network;
1669
unsigned int if_index = if_nametoindex(interface);
1671
fprintf_plus(stderr, "No such interface: \"%s\"\n", interface);
1681
if(not interface_is_up(interface)){
1682
error_t ret_errno = 0, ioctl_errno = 0;
1683
if(not get_flags(interface, &network)){
1685
fprintf_plus(stderr, "Failed to get flags for interface "
1686
"\"%s\"\n", interface);
1690
network.ifr_flags |= IFF_UP; /* set flag */
1692
int sd = socket(PF_INET6, SOCK_DGRAM, IPPROTO_IP);
1695
perror_plus("socket");
1701
ret = (int)TEMP_FAILURE_RETRY(close(sd));
1703
perror_plus("close");
1710
fprintf_plus(stderr, "Bringing up interface \"%s\"\n",
1714
/* Raise privileges */
1715
ret_errno = raise_privileges();
1716
bool restore_loglevel = false;
1718
perror_plus("Failed to raise privileges");
1723
/* Lower kernel loglevel to KERN_NOTICE to avoid KERN_INFO
1724
messages about the network interface to mess up the prompt */
1725
ret_linux = klogctl(8, NULL, 5);
1726
if(ret_linux == -1){
1727
perror_plus("klogctl");
1729
restore_loglevel = true;
1732
#endif /* __linux__ */
1733
int ret_setflags = ioctl(sd, SIOCSIFFLAGS, &network);
1734
ioctl_errno = errno;
1736
if(restore_loglevel){
1737
ret_linux = klogctl(7, NULL, 0);
1738
if(ret_linux == -1){
1739
perror_plus("klogctl");
1742
#endif /* __linux__ */
1744
/* If raise_privileges() succeeded above */
1746
/* Lower privileges */
1747
ret_errno = lower_privileges();
1750
perror_plus("Failed to lower privileges");
1754
/* Close the socket */
1755
ret = (int)TEMP_FAILURE_RETRY(close(sd));
1757
perror_plus("close");
1760
if(ret_setflags == -1){
1761
errno = ioctl_errno;
1762
perror_plus("ioctl SIOCSIFFLAGS +IFF_UP");
1767
fprintf_plus(stderr, "Interface \"%s\" is already up; good\n",
1771
/* Sleep checking until interface is running.
1772
Check every 0.25s, up to total time of delay */
1773
for(int i=0; i < delay * 4; i++){
1774
if(interface_is_running(interface)){
1777
struct timespec sleeptime = { .tv_nsec = 250000000 };
1778
ret = nanosleep(&sleeptime, NULL);
1779
if(ret == -1 and errno != EINTR){
1780
perror_plus("nanosleep");
1788
__attribute__((nonnull, warn_unused_result))
1789
error_t take_down_interface(const char *const interface){
1790
error_t old_errno = errno;
1791
struct ifreq network;
1792
unsigned int if_index = if_nametoindex(interface);
1794
fprintf_plus(stderr, "No such interface: \"%s\"\n", interface);
1798
if(interface_is_up(interface)){
1799
error_t ret_errno = 0, ioctl_errno = 0;
1800
if(not get_flags(interface, &network) and debug){
1802
fprintf_plus(stderr, "Failed to get flags for interface "
1803
"\"%s\"\n", interface);
1807
network.ifr_flags &= ~(short)IFF_UP; /* clear flag */
1809
int sd = socket(PF_INET6, SOCK_DGRAM, IPPROTO_IP);
1812
perror_plus("socket");
1818
fprintf_plus(stderr, "Taking down interface \"%s\"\n",
1822
/* Raise privileges */
1823
ret_errno = raise_privileges();
1825
perror_plus("Failed to raise privileges");
1827
int ret_setflags = ioctl(sd, SIOCSIFFLAGS, &network);
1828
ioctl_errno = errno;
1830
/* If raise_privileges() succeeded above */
1832
/* Lower privileges */
1833
ret_errno = lower_privileges();
1836
perror_plus("Failed to lower privileges");
1840
/* Close the socket */
1841
int ret = (int)TEMP_FAILURE_RETRY(close(sd));
1843
perror_plus("close");
1846
if(ret_setflags == -1){
1847
errno = ioctl_errno;
1848
perror_plus("ioctl SIOCSIFFLAGS -IFF_UP");
1853
fprintf_plus(stderr, "Interface \"%s\" is already down; odd\n",
1861
int main(int argc, char *argv[]){
1862
mandos_context mc = { .server = NULL, .dh_bits = 1024,
1863
.priority = "SECURE256:!CTYPE-X.509:"
1864
"+CTYPE-OPENPGP", .current_server = NULL,
1865
.interfaces = NULL, .interfaces_size = 0 };
1866
AvahiSServiceBrowser *sb = NULL;
1871
int exitcode = EXIT_SUCCESS;
1872
char *interfaces_to_take_down = NULL;
1873
size_t interfaces_to_take_down_size = 0;
1874
char tempdir[] = "/tmp/mandosXXXXXX";
1875
bool tempdir_created = false;
1876
AvahiIfIndex if_index = AVAHI_IF_UNSPEC;
1877
const char *seckey = PATHDIR "/" SECKEY;
1878
const char *pubkey = PATHDIR "/" PUBKEY;
1879
char *interfaces_hooks = NULL;
1881
bool gnutls_initialized = false;
1882
bool gpgme_initialized = false;
1884
double retry_interval = 10; /* 10s between trying a server and
1885
retrying the same server again */
1887
struct sigaction old_sigterm_action = { .sa_handler = SIG_DFL };
1888
struct sigaction sigterm_action = { .sa_handler = handle_sigterm };
1893
/* Lower any group privileges we might have, just to be safe */
1897
perror_plus("setgid");
1900
/* Lower user privileges (temporarily) */
1904
perror_plus("seteuid");
1912
struct argp_option options[] = {
1913
{ .name = "debug", .key = 128,
1914
.doc = "Debug mode", .group = 3 },
1915
{ .name = "connect", .key = 'c',
1916
.arg = "ADDRESS:PORT",
1917
.doc = "Connect directly to a specific Mandos server",
1919
{ .name = "interface", .key = 'i',
1921
.doc = "Network interface that will be used to search for"
1924
{ .name = "seckey", .key = 's',
1926
.doc = "OpenPGP secret key file base name",
1928
{ .name = "pubkey", .key = 'p',
1930
.doc = "OpenPGP public key file base name",
1932
{ .name = "dh-bits", .key = 129,
1934
.doc = "Bit length of the prime number used in the"
1935
" Diffie-Hellman key exchange",
1937
{ .name = "priority", .key = 130,
1939
.doc = "GnuTLS priority string for the TLS handshake",
1941
{ .name = "delay", .key = 131,
1943
.doc = "Maximum delay to wait for interface startup",
1945
{ .name = "retry", .key = 132,
1947
.doc = "Retry interval used when denied by the Mandos server",
1949
{ .name = "network-hook-dir", .key = 133,
1951
.doc = "Directory where network hooks are located",
1954
* These reproduce what we would get without ARGP_NO_HELP
1956
{ .name = "help", .key = '?',
1957
.doc = "Give this help list", .group = -1 },
1958
{ .name = "usage", .key = -3,
1959
.doc = "Give a short usage message", .group = -1 },
1960
{ .name = "version", .key = 'V',
1961
.doc = "Print program version", .group = -1 },
1965
error_t parse_opt(int key, char *arg,
1966
struct argp_state *state){
1969
case 128: /* --debug */
1972
case 'c': /* --connect */
1975
case 'i': /* --interface */
1976
ret_errno = argz_add_sep(&mc.interfaces, &mc.interfaces_size,
1979
argp_error(state, "%s", strerror(ret_errno));
1982
case 's': /* --seckey */
1985
case 'p': /* --pubkey */
1988
case 129: /* --dh-bits */
1990
tmpmax = strtoimax(arg, &tmp, 10);
1991
if(errno != 0 or tmp == arg or *tmp != '\0'
1992
or tmpmax != (typeof(mc.dh_bits))tmpmax){
1993
argp_error(state, "Bad number of DH bits");
1995
mc.dh_bits = (typeof(mc.dh_bits))tmpmax;
1997
case 130: /* --priority */
2000
case 131: /* --delay */
2002
delay = strtof(arg, &tmp);
2003
if(errno != 0 or tmp == arg or *tmp != '\0'){
2004
argp_error(state, "Bad delay");
2006
case 132: /* --retry */
2008
retry_interval = strtod(arg, &tmp);
2009
if(errno != 0 or tmp == arg or *tmp != '\0'
2010
or (retry_interval * 1000) > INT_MAX
2011
or retry_interval < 0){
2012
argp_error(state, "Bad retry interval");
2015
case 133: /* --network-hook-dir */
2019
* These reproduce what we would get without ARGP_NO_HELP
2021
case '?': /* --help */
2022
argp_state_help(state, state->out_stream,
2023
(ARGP_HELP_STD_HELP | ARGP_HELP_EXIT_ERR)
2024
& ~(unsigned int)ARGP_HELP_EXIT_OK);
2025
case -3: /* --usage */
2026
argp_state_help(state, state->out_stream,
2027
ARGP_HELP_USAGE | ARGP_HELP_EXIT_ERR);
2028
case 'V': /* --version */
2029
fprintf_plus(state->out_stream, "%s\n", argp_program_version);
2030
exit(argp_err_exit_status);
2033
return ARGP_ERR_UNKNOWN;
2038
struct argp argp = { .options = options, .parser = parse_opt,
2040
.doc = "Mandos client -- Get and decrypt"
2041
" passwords from a Mandos server" };
2042
ret = argp_parse(&argp, argc, argv,
2043
ARGP_IN_ORDER | ARGP_NO_HELP, 0, NULL);
594
case AVAHI_BROWSER_FAILURE:
596
fprintf(stderr, "(Browser) %s\n",
597
avahi_strerror(avahi_server_errno(server)));
598
avahi_simple_poll_quit(simple_poll);
601
case AVAHI_BROWSER_NEW:
602
/* We ignore the returned resolver object. In the callback
603
function we free it. If the server is terminated before
604
the callback function is called the server will free
605
the resolver for us. */
607
if (!(avahi_s_service_resolver_new(s, interface, protocol, name,
609
AVAHI_PROTO_INET6, 0,
610
resolve_callback, s)))
611
fprintf(stderr, "Failed to resolve service '%s': %s\n", name,
612
avahi_strerror(avahi_server_errno(s)));
615
case AVAHI_BROWSER_REMOVE:
618
case AVAHI_BROWSER_ALL_FOR_NOW:
619
case AVAHI_BROWSER_CACHE_EXHAUSTED:
624
/* combinds file name and path and returns the malloced new string. som sane checks could/should be added */
625
const char *combinepath(const char *first, const char *second){
627
tmp = malloc(strlen(first) + strlen(second) + 2);
633
if (first[0] != '\0' and first[strlen(first) - 1] != '/'){
641
int main(AVAHI_GCC_UNUSED int argc, AVAHI_GCC_UNUSED char*argv[]) {
2050
perror_plus("argp_parse");
2051
exitcode = EX_OSERR;
2054
exitcode = EX_USAGE;
2060
/* Work around Debian bug #633582:
2061
<http://bugs.debian.org/633582> */
2063
/* Re-raise privileges */
2064
ret_errno = raise_privileges();
2067
perror_plus("Failed to raise privileges");
2071
if(strcmp(seckey, PATHDIR "/" SECKEY) == 0){
2072
int seckey_fd = open(seckey, O_RDONLY);
2073
if(seckey_fd == -1){
2074
perror_plus("open");
2076
ret = (int)TEMP_FAILURE_RETRY(fstat(seckey_fd, &st));
2078
perror_plus("fstat");
2080
if(S_ISREG(st.st_mode)
2081
and st.st_uid == 0 and st.st_gid == 0){
2082
ret = fchown(seckey_fd, uid, gid);
2084
perror_plus("fchown");
2088
TEMP_FAILURE_RETRY(close(seckey_fd));
2092
if(strcmp(pubkey, PATHDIR "/" PUBKEY) == 0){
2093
int pubkey_fd = open(pubkey, O_RDONLY);
2094
if(pubkey_fd == -1){
2095
perror_plus("open");
2097
ret = (int)TEMP_FAILURE_RETRY(fstat(pubkey_fd, &st));
2099
perror_plus("fstat");
2101
if(S_ISREG(st.st_mode)
2102
and st.st_uid == 0 and st.st_gid == 0){
2103
ret = fchown(pubkey_fd, uid, gid);
2105
perror_plus("fchown");
2109
TEMP_FAILURE_RETRY(close(pubkey_fd));
2113
/* Lower privileges */
2114
ret_errno = lower_privileges();
2117
perror_plus("Failed to lower privileges");
2122
/* Remove invalid interface names (except "none") */
2124
char *interface = NULL;
2125
while((interface = argz_next(mc.interfaces, mc.interfaces_size,
2127
if(strcmp(interface, "none") != 0
2128
and if_nametoindex(interface) == 0){
2129
if(interface[0] != '\0'){
2130
fprintf_plus(stderr, "Not using nonexisting interface"
2131
" \"%s\"\n", interface);
2133
argz_delete(&mc.interfaces, &mc.interfaces_size, interface);
2139
/* Run network hooks */
2141
if(mc.interfaces != NULL){
2142
interfaces_hooks = malloc(mc.interfaces_size);
2143
if(interfaces_hooks == NULL){
2144
perror_plus("malloc");
2147
memcpy(interfaces_hooks, mc.interfaces, mc.interfaces_size);
2148
argz_stringify(interfaces_hooks, mc.interfaces_size, (int)',');
2150
run_network_hooks("start", interfaces_hooks != NULL ?
2151
interfaces_hooks : "", delay);
2155
avahi_set_log_function(empty_log);
2158
/* Initialize Avahi early so avahi_simple_poll_quit() can be called
2159
from the signal handler */
2160
/* Initialize the pseudo-RNG for Avahi */
2161
srand((unsigned int) time(NULL));
2162
simple_poll = avahi_simple_poll_new();
2163
if(simple_poll == NULL){
2164
fprintf_plus(stderr,
2165
"Avahi: Failed to create simple poll object.\n");
2166
exitcode = EX_UNAVAILABLE;
2170
sigemptyset(&sigterm_action.sa_mask);
2171
ret = sigaddset(&sigterm_action.sa_mask, SIGINT);
2173
perror_plus("sigaddset");
2174
exitcode = EX_OSERR;
2177
ret = sigaddset(&sigterm_action.sa_mask, SIGHUP);
2179
perror_plus("sigaddset");
2180
exitcode = EX_OSERR;
2183
ret = sigaddset(&sigterm_action.sa_mask, SIGTERM);
2185
perror_plus("sigaddset");
2186
exitcode = EX_OSERR;
2189
/* Need to check if the handler is SIG_IGN before handling:
2190
| [[info:libc:Initial Signal Actions]] |
2191
| [[info:libc:Basic Signal Handling]] |
2193
ret = sigaction(SIGINT, NULL, &old_sigterm_action);
2195
perror_plus("sigaction");
2198
if(old_sigterm_action.sa_handler != SIG_IGN){
2199
ret = sigaction(SIGINT, &sigterm_action, NULL);
2201
perror_plus("sigaction");
2202
exitcode = EX_OSERR;
2206
ret = sigaction(SIGHUP, NULL, &old_sigterm_action);
2208
perror_plus("sigaction");
2211
if(old_sigterm_action.sa_handler != SIG_IGN){
2212
ret = sigaction(SIGHUP, &sigterm_action, NULL);
2214
perror_plus("sigaction");
2215
exitcode = EX_OSERR;
2219
ret = sigaction(SIGTERM, NULL, &old_sigterm_action);
2221
perror_plus("sigaction");
2224
if(old_sigterm_action.sa_handler != SIG_IGN){
2225
ret = sigaction(SIGTERM, &sigterm_action, NULL);
2227
perror_plus("sigaction");
2228
exitcode = EX_OSERR;
2233
/* If no interfaces were specified, make a list */
2234
if(mc.interfaces == NULL){
2235
struct dirent **direntries;
2236
/* Look for any good interfaces */
2237
ret = scandir(sys_class_net, &direntries, good_interface,
2240
/* Add all found interfaces to interfaces list */
2241
for(int i = 0; i < ret; ++i){
2242
ret_errno = argz_add(&mc.interfaces, &mc.interfaces_size,
2243
direntries[i]->d_name);
2246
perror_plus("argz_add");
2250
fprintf_plus(stderr, "Will use interface \"%s\"\n",
2251
direntries[i]->d_name);
2257
fprintf_plus(stderr, "Could not find a network interface\n");
2258
exitcode = EXIT_FAILURE;
2263
/* Bring up interfaces which are down, and remove any "none"s */
2265
char *interface = NULL;
2266
while((interface = argz_next(mc.interfaces, mc.interfaces_size,
2268
/* If interface name is "none", stop bringing up interfaces.
2269
Also remove all instances of "none" from the list */
2270
if(strcmp(interface, "none") == 0){
2271
argz_delete(&mc.interfaces, &mc.interfaces_size,
2274
while((interface = argz_next(mc.interfaces,
2275
mc.interfaces_size, interface))){
2276
if(strcmp(interface, "none") == 0){
2277
argz_delete(&mc.interfaces, &mc.interfaces_size,
2284
bool interface_was_up = interface_is_up(interface);
2285
errno = bring_up_interface(interface, delay);
2286
if(not interface_was_up){
2288
perror_plus("Failed to bring up interface");
2290
errno = argz_add(&interfaces_to_take_down,
2291
&interfaces_to_take_down_size,
2294
perror_plus("argz_add");
2299
if(debug and (interfaces_to_take_down == NULL)){
2300
fprintf_plus(stderr, "No interfaces were brought up\n");
2304
/* If we only got one interface, explicitly use only that one */
2305
if(argz_count(mc.interfaces, mc.interfaces_size) == 1){
2307
fprintf_plus(stderr, "Using only interface \"%s\"\n",
2310
if_index = (AvahiIfIndex)if_nametoindex(mc.interfaces);
2317
ret = init_gnutls_global(pubkey, seckey, &mc);
2319
fprintf_plus(stderr, "init_gnutls_global failed\n");
2320
exitcode = EX_UNAVAILABLE;
2323
gnutls_initialized = true;
2330
if(mkdtemp(tempdir) == NULL){
2331
perror_plus("mkdtemp");
2334
tempdir_created = true;
2340
if(not init_gpgme(pubkey, seckey, tempdir, &mc)){
2341
fprintf_plus(stderr, "init_gpgme failed\n");
2342
exitcode = EX_UNAVAILABLE;
2345
gpgme_initialized = true;
2352
if(connect_to != NULL){
2353
/* Connect directly, do not use Zeroconf */
2354
/* (Mainly meant for debugging) */
2355
char *address = strrchr(connect_to, ':');
2357
if(address == NULL){
2358
fprintf_plus(stderr, "No colon in address\n");
2359
exitcode = EX_USAGE;
2369
tmpmax = strtoimax(address+1, &tmp, 10);
2370
if(errno != 0 or tmp == address+1 or *tmp != '\0'
2371
or tmpmax != (in_port_t)tmpmax){
2372
fprintf_plus(stderr, "Bad port number\n");
2373
exitcode = EX_USAGE;
2381
port = (in_port_t)tmpmax;
2383
/* Colon in address indicates IPv6 */
2385
if(strchr(connect_to, ':') != NULL){
2387
/* Accept [] around IPv6 address - see RFC 5952 */
2388
if(connect_to[0] == '[' and address[-1] == ']')
2396
address = connect_to;
2402
while(not quit_now){
2403
ret = start_mandos_communication(address, port, if_index, af,
2405
if(quit_now or ret == 0){
2409
fprintf_plus(stderr, "Retrying in %d seconds\n",
2410
(int)retry_interval);
2412
sleep((unsigned int)retry_interval);
2416
exitcode = EXIT_SUCCESS;
642
2427
AvahiServerConfig config;
643
AvahiSServiceBrowser *sb = NULL;
646
int returncode = EXIT_SUCCESS;
647
const char *interface = "eth0";
650
static struct option long_options[] = {
651
{"debug", no_argument, (int *)&debug, 1},
652
{"interface", required_argument, 0, 'i'},
653
{"certdir", required_argument, 0, 'd'},
654
{"certkey", required_argument, 0, 'c'},
655
{"certfile", required_argument, 0, 'k'},
658
int option_index = 0;
659
ret = getopt_long (argc, argv, "i:", long_options,
686
certfile = combinepath(certdir, certfile);
687
if (certfile == NULL){
691
certkey = combinepath(certdir, certkey);
692
if (certkey == NULL){
697
avahi_set_log_function(empty_log);
700
/* Initialize the psuedo-RNG */
701
srand((unsigned int) time(NULL));
703
/* Allocate main loop object */
704
if (!(simple_poll = avahi_simple_poll_new())) {
705
fprintf(stderr, "Failed to create simple poll object.\n");
710
/* Do not publish any local records */
2428
/* Do not publish any local Zeroconf records */
711
2429
avahi_server_config_init(&config);
712
2430
config.publish_hinfo = 0;
713
2431
config.publish_addresses = 0;
714
2432
config.publish_workstation = 0;
715
2433
config.publish_domain = 0;
717
2435
/* Allocate a new server */
718
server = avahi_server_new(avahi_simple_poll_get(simple_poll),
719
&config, NULL, NULL, &error);
721
/* Free the configuration data */
2436
mc.server = avahi_server_new(avahi_simple_poll_get(simple_poll),
2437
&config, NULL, NULL, &ret_errno);
2439
/* Free the Avahi configuration data */
722
2440
avahi_server_config_free(&config);
724
/* Check if creating the server object succeeded */
726
fprintf(stderr, "Failed to create server: %s\n",
727
avahi_strerror(error));
728
returncode = EXIT_FAILURE;
732
/* Create the service browser */
733
sb = avahi_s_service_browser_new(server,
735
if_nametoindex(interface),
737
"_mandos._tcp", NULL, 0,
738
browse_callback, server);
740
fprintf(stderr, "Failed to create service browser: %s\n",
741
avahi_strerror(avahi_server_errno(server)));
742
returncode = EXIT_FAILURE;
746
/* Run the main loop */
749
fprintf(stderr, "Starting avahi loop search\n");
752
avahi_simple_poll_loop(simple_poll);
757
fprintf(stderr, "%s exiting\n", argv[0]);
762
avahi_s_service_browser_free(sb);
765
avahi_server_free(server);
768
avahi_simple_poll_free(simple_poll);
2443
/* Check if creating the Avahi server object succeeded */
2444
if(mc.server == NULL){
2445
fprintf_plus(stderr, "Failed to create Avahi server: %s\n",
2446
avahi_strerror(ret_errno));
2447
exitcode = EX_UNAVAILABLE;
2455
/* Create the Avahi service browser */
2456
sb = avahi_s_service_browser_new(mc.server, if_index,
2457
AVAHI_PROTO_UNSPEC, "_mandos._tcp",
2458
NULL, 0, browse_callback,
2461
fprintf_plus(stderr, "Failed to create service browser: %s\n",
2462
avahi_strerror(avahi_server_errno(mc.server)));
2463
exitcode = EX_UNAVAILABLE;
2471
/* Run the main loop */
2474
fprintf_plus(stderr, "Starting Avahi loop search\n");
2477
ret = avahi_loop_with_timeout(simple_poll,
2478
(int)(retry_interval * 1000), &mc);
2480
fprintf_plus(stderr, "avahi_loop_with_timeout exited %s\n",
2481
(ret == 0) ? "successfully" : "with error");
2487
fprintf_plus(stderr, "%s exiting\n", argv[0]);
2490
/* Cleanup things */
2491
free(mc.interfaces);
2494
avahi_s_service_browser_free(sb);
2496
if(mc.server != NULL)
2497
avahi_server_free(mc.server);
2499
if(simple_poll != NULL)
2500
avahi_simple_poll_free(simple_poll);
2502
if(gnutls_initialized){
2503
gnutls_certificate_free_credentials(mc.cred);
2504
gnutls_global_deinit();
2505
gnutls_dh_params_deinit(mc.dh_params);
2508
if(gpgme_initialized){
2509
gpgme_release(mc.ctx);
2512
/* Cleans up the circular linked list of Mandos servers the client
2514
if(mc.current_server != NULL){
2515
mc.current_server->prev->next = NULL;
2516
while(mc.current_server != NULL){
2517
server *next = mc.current_server->next;
2518
free(mc.current_server);
2519
mc.current_server = next;
2523
/* Re-raise privileges */
2525
ret_errno = raise_privileges();
2527
perror_plus("Failed to raise privileges");
2530
/* Run network hooks */
2531
run_network_hooks("stop", interfaces_hooks != NULL ?
2532
interfaces_hooks : "", delay);
2534
/* Take down the network interfaces which were brought up */
2536
char *interface = NULL;
2537
while((interface=argz_next(interfaces_to_take_down,
2538
interfaces_to_take_down_size,
2540
ret_errno = take_down_interface(interface);
2543
perror_plus("Failed to take down interface");
2546
if(debug and (interfaces_to_take_down == NULL)){
2547
fprintf_plus(stderr, "No interfaces needed to be taken"
2552
ret_errno = lower_privileges_permanently();
2554
perror_plus("Failed to lower privileges permanently");
2558
free(interfaces_to_take_down);
2559
free(interfaces_hooks);
2561
/* Removes the GPGME temp directory and all files inside */
2562
if(tempdir_created){
2563
struct dirent **direntries = NULL;
2564
struct dirent *direntry = NULL;
2565
int numentries = scandir(tempdir, &direntries, notdotentries,
2568
for(int i = 0; i < numentries; i++){
2569
direntry = direntries[i];
2570
char *fullname = NULL;
2571
ret = asprintf(&fullname, "%s/%s", tempdir,
2574
perror_plus("asprintf");
2577
ret = remove(fullname);
2579
fprintf_plus(stderr, "remove(\"%s\"): %s\n", fullname,
2586
/* need to clean even if 0 because man page doesn't specify */
2588
if(numentries == -1){
2589
perror_plus("scandir");
2591
ret = rmdir(tempdir);
2592
if(ret == -1 and errno != ENOENT){
2593
perror_plus("rmdir");
2598
sigemptyset(&old_sigterm_action.sa_mask);
2599
old_sigterm_action.sa_handler = SIG_DFL;
2600
ret = (int)TEMP_FAILURE_RETRY(sigaction(signal_received,
2601
&old_sigterm_action,
2604
perror_plus("sigaction");
2607
ret = raise(signal_received);
2608
} while(ret != 0 and errno == EINTR);
2610
perror_plus("raise");
2613
TEMP_FAILURE_RETRY(pause());