32
32
/* Needed by GPGME, specifically gpgme_data_seek() */
33
#ifndef _LARGEFILE_SOURCE
34
33
#define _LARGEFILE_SOURCE
36
#ifndef _FILE_OFFSET_BITS
37
34
#define _FILE_OFFSET_BITS 64
40
36
#define _GNU_SOURCE /* TEMP_FAILURE_RETRY(), asprintf() */
71
67
INET_ADDRSTRLEN, INET6_ADDRSTRLEN
73
69
#include <unistd.h> /* close(), SEEK_SET, off_t, write(),
74
getuid(), getgid(), seteuid(),
70
getuid(), getgid(), setuid(),
76
72
#include <arpa/inet.h> /* inet_pton(), htons */
77
73
#include <iso646.h> /* not, or, and */
80
76
argp_parse(), ARGP_KEY_ARG,
81
77
ARGP_KEY_END, ARGP_ERR_UNKNOWN */
82
78
#include <signal.h> /* sigemptyset(), sigaddset(),
83
sigaction(), SIGTERM, sig_atomic_t,
79
sigaction(), SIGTERM, sigaction,
87
83
#include <sys/klog.h> /* klogctl() */
142
138
.dh_bits = 1024, .priority = "SECURE256"
143
139
":!CTYPE-X.509:+CTYPE-OPENPGP" };
145
sig_atomic_t quit_now = 0;
146
int signal_received = 0;
149
142
* Make additional room in "buffer" for at least BUFFER_SIZE more
150
143
* bytes. "buffer_capacity" is how much is currently allocated,
313
306
gpgme_recipient_t recipient;
314
307
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
322
recipient = recipient->next;
309
while(recipient != NULL){
310
fprintf(stderr, "Public key algorithm: %s\n",
311
gpgme_pubkey_algo_name(recipient->pubkey_algo));
312
fprintf(stderr, "Key ID: %s\n", recipient->keyid);
313
fprintf(stderr, "Secret key available: %s\n",
314
recipient->status == GPG_ERR_NO_SECKEY
316
recipient = recipient->next;
477
472
static int init_gnutls_session(gnutls_session_t *session){
479
474
/* GnuTLS session creation */
481
ret = gnutls_init(session, GNUTLS_SERVER);
485
} while(ret == GNUTLS_E_INTERRUPTED or ret == GNUTLS_E_AGAIN);
475
ret = gnutls_init(session, GNUTLS_SERVER);
486
476
if(ret != GNUTLS_E_SUCCESS){
487
477
fprintf(stderr, "Error in GnuTLS session initialization: %s\n",
488
478
safer_gnutls_strerror(ret));
494
ret = gnutls_priority_set_direct(*session, mc.priority, &err);
496
gnutls_deinit(*session);
499
} while(ret == GNUTLS_E_INTERRUPTED or ret == GNUTLS_E_AGAIN);
483
ret = gnutls_priority_set_direct(*session, mc.priority, &err);
500
484
if(ret != GNUTLS_E_SUCCESS){
501
485
fprintf(stderr, "Syntax error at: %s\n", err);
502
486
fprintf(stderr, "GnuTLS error: %s\n",
510
ret = gnutls_credentials_set(*session, GNUTLS_CRD_CERTIFICATE,
513
gnutls_deinit(*session);
516
} while(ret == GNUTLS_E_INTERRUPTED or ret == GNUTLS_E_AGAIN);
493
ret = gnutls_credentials_set(*session, GNUTLS_CRD_CERTIFICATE,
517
495
if(ret != GNUTLS_E_SUCCESS){
518
496
fprintf(stderr, "Error setting GnuTLS credentials: %s\n",
519
497
safer_gnutls_strerror(ret));
524
502
/* ignore client certificate if any. */
525
gnutls_certificate_server_set_request(*session, GNUTLS_CERT_IGNORE);
503
gnutls_certificate_server_set_request(*session,
527
506
gnutls_dh_set_prime_bits(*session, mc.dh_bits);
547
526
char *decrypted_buffer;
548
527
size_t buffer_length = 0;
549
528
size_t buffer_capacity = 0;
529
ssize_t decrypted_buffer_size;
552
532
gnutls_session_t session;
553
533
int pf; /* Protocol family */
581
557
tcp_sd = socket(pf, SOCK_STREAM, 0);
583
559
perror("socket");
593
563
memset(&to, 0, sizeof(to));
594
564
if(af == AF_INET6){
595
to.in6.sin6_family = (sa_family_t)af;
565
to.in6.sin6_family = (uint16_t)af;
596
566
ret = inet_pton(af, ip, &to.in6.sin6_addr);
597
567
} else { /* IPv4 */
598
568
to.in.sin_family = (sa_family_t)af;
619
587
if(if_index == AVAHI_IF_UNSPEC){
620
588
fprintf(stderr, "An IPv6 link-local address is incomplete"
621
589
" without a network interface\n");
625
592
/* Set the network interface number as scope */
626
593
to.in6.sin6_scope_id = (uint32_t)if_index;
722
668
fprintf(stderr, "Establishing TLS session with %s\n", ip);
730
671
gnutls_transport_set_ptr(session, (gnutls_transport_ptr_t) tcp_sd);
738
674
ret = gnutls_handshake(session);
743
675
} while(ret == GNUTLS_E_AGAIN or ret == GNUTLS_E_INTERRUPTED);
745
677
if(ret != GNUTLS_E_SUCCESS){
789
710
case GNUTLS_E_AGAIN:
791
712
case GNUTLS_E_REHANDSHAKE:
793
714
ret = gnutls_handshake(session);
799
715
} while(ret == GNUTLS_E_AGAIN or ret == GNUTLS_E_INTERRUPTED);
801
717
fprintf(stderr, "*** GnuTLS Re-handshake failed ***\n");
820
736
fprintf(stderr, "Closing TLS session\n");
829
ret = gnutls_bye(session, GNUTLS_SHUT_RDWR);
834
} while(ret == GNUTLS_E_AGAIN or ret == GNUTLS_E_INTERRUPTED);
739
gnutls_bye(session, GNUTLS_SHUT_RDWR);
836
741
if(buffer_length > 0){
837
ssize_t decrypted_buffer_size;
838
742
decrypted_buffer_size = pgp_packet_decrypt(buffer,
840
744
&decrypted_buffer);
841
745
if(decrypted_buffer_size >= 0){
844
747
while(written < (size_t) decrypted_buffer_size){
850
748
ret = (int)fwrite(decrypted_buffer + written, 1,
851
749
(size_t)decrypted_buffer_size - written,
969
854
the callback function is called the Avahi server will free the
970
855
resolver for us. */
972
if(avahi_s_service_resolver_new(mc.server, interface, protocol,
973
name, type, domain, protocol, 0,
974
resolve_callback, NULL) == NULL)
857
if(!(avahi_s_service_resolver_new(mc.server, interface,
858
protocol, name, type, domain,
859
AVAHI_PROTO_INET6, 0,
860
resolve_callback, NULL)))
975
861
fprintf(stderr, "Avahi: Failed to resolve service '%s': %s\n",
976
862
name, avahi_strerror(avahi_server_errno(mc.server)));
877
sig_atomic_t quit_now = 0;
991
879
/* stop main loop after sigterm has been called */
992
static void handle_sigterm(int sig){
880
static void handle_sigterm(__attribute__((unused)) int sig){
997
signal_received = sig;
998
885
int old_errno = errno;
999
886
if(mc.simple_poll != NULL){
1000
887
avahi_simple_poll_quit(mc.simple_poll);
1022
908
const char *seckey = PATHDIR "/" SECKEY;
1023
909
const char *pubkey = PATHDIR "/" PUBKEY;
911
/* Initialize Mandos context */
912
mc = (mandos_context){ .simple_poll = NULL, .server = NULL,
913
.dh_bits = 1024, .priority = "SECURE256"
914
":!CTYPE-X.509:+CTYPE-OPENPGP" };
1025
915
bool gnutls_initialized = false;
1026
916
bool gpgme_initialized = false;
1027
917
float delay = 2.5f;
1029
struct sigaction old_sigterm_action = { .sa_handler = SIG_DFL };
919
struct sigaction old_sigterm_action;
1030
920
struct sigaction sigterm_action = { .sa_handler = handle_sigterm };
1035
/* Lower any group privileges we might have, just to be safe */
1042
/* Lower user privileges (temporarily) */
1054
923
struct argp_option options[] = {
1055
924
{ .name = "debug", .key = 128,
1182
1051
exitcode = EXIT_FAILURE;
1185
/* Need to check if the handler is SIG_IGN before handling:
1186
| [[info:libc:Initial Signal Actions]] |
1187
| [[info:libc:Basic Signal Handling]] |
1189
ret = sigaction(SIGINT, NULL, &old_sigterm_action);
1191
perror("sigaction");
1192
return EXIT_FAILURE;
1194
if(old_sigterm_action.sa_handler != SIG_IGN){
1195
ret = sigaction(SIGINT, &sigterm_action, NULL);
1197
perror("sigaction");
1198
exitcode = EXIT_FAILURE;
1202
ret = sigaction(SIGHUP, NULL, &old_sigterm_action);
1204
perror("sigaction");
1205
return EXIT_FAILURE;
1207
if(old_sigterm_action.sa_handler != SIG_IGN){
1208
ret = sigaction(SIGHUP, &sigterm_action, NULL);
1210
perror("sigaction");
1211
exitcode = EXIT_FAILURE;
1215
ret = sigaction(SIGTERM, NULL, &old_sigterm_action);
1217
perror("sigaction");
1218
return EXIT_FAILURE;
1220
if(old_sigterm_action.sa_handler != SIG_IGN){
1221
ret = sigaction(SIGTERM, &sigterm_action, NULL);
1223
perror("sigaction");
1224
exitcode = EXIT_FAILURE;
1054
ret = sigaction(SIGTERM, &sigterm_action, &old_sigterm_action);
1056
perror("sigaction");
1057
exitcode = EXIT_FAILURE;
1229
1061
/* If the interface is down, bring it up */
1230
1062
if(interface[0] != '\0'){
1231
if_index = (AvahiIfIndex) if_nametoindex(interface);
1233
fprintf(stderr, "No such interface: \"%s\"\n", interface);
1234
exitcode = EXIT_FAILURE;
1242
/* Re-raise priviliges */
1249
1063
#ifdef __linux__
1250
1064
/* Lower kernel loglevel to KERN_NOTICE to avoid KERN_INFO
1251
1065
messages to mess up the prompt */
1291
1099
#endif /* __linux__ */
1292
1100
exitcode = EXIT_FAILURE;
1293
/* Lower privileges */
1301
1103
if((network.ifr_flags & IFF_UP) == 0){
1302
1104
network.ifr_flags |= IFF_UP;
1303
take_down_interface = true;
1304
1105
ret = ioctl(sd, SIOCSIFFLAGS, &network);
1306
take_down_interface = false;
1307
1107
perror("ioctl SIOCSIFFLAGS");
1308
1108
exitcode = EXIT_FAILURE;
1309
1109
#ifdef __linux__
1383
1169
gnutls_initialized = true;
1390
tempdir_created = true;
1391
1172
if(mkdtemp(tempdir) == NULL){
1392
tempdir_created = false;
1393
1173
perror("mkdtemp");
1176
tempdir_created = true;
1401
1178
if(not init_gpgme(pubkey, seckey, tempdir)){
1402
1179
fprintf(stderr, "init_gpgme failed\n");
1406
1183
gpgme_initialized = true;
1186
if(interface[0] != '\0'){
1187
if_index = (AvahiIfIndex) if_nametoindex(interface);
1189
fprintf(stderr, "No such interface: \"%s\"\n", interface);
1190
exitcode = EXIT_FAILURE;
1413
1195
if(connect_to != NULL){
1499
1258
/* Create the Avahi service browser */
1500
1259
sb = avahi_s_service_browser_new(mc.server, if_index,
1501
AVAHI_PROTO_UNSPEC, "_mandos._tcp",
1260
AVAHI_PROTO_INET6, "_mandos._tcp",
1502
1261
NULL, 0, browse_callback, NULL);
1503
1262
if(sb == NULL){
1504
1263
fprintf(stderr, "Failed to create service browser: %s\n",
1545
1300
gpgme_release(mc.ctx);
1548
/* Take down the network interface */
1549
if(take_down_interface){
1550
/* Re-raise priviliges */
1557
ret = ioctl(sd, SIOCGIFFLAGS, &network);
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);
1564
perror("ioctl SIOCSIFFLAGS");
1567
ret = (int)TEMP_FAILURE_RETRY(close(sd));
1571
/* Lower privileges permanently */
1580
1303
/* Removes the temp directory used by GPGME */
1581
1304
if(tempdir_created){