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 426
- compare with another revision
- download diff
- download tarball
- view history from revision 426
- Committer: Teddy Hogeborn
- Date: 2010-09-12 03:22:48 UTC
- Revision ID: teddy@fukt.bsnet.se-20100912032248-6cizkymqivr5uzwm
* Makefile (run-server): Remove warning about now-eliminated error.
added
removed
plugins.d/mandos-client.c
43
43
stdout, ferror(), remove() */
44
44
#include <stdint.h> /* uint16_t, uint32_t */
45
45
#include <stddef.h> /* NULL, size_t, ssize_t */
46
#include <stdlib.h> /* free(), EXIT_SUCCESS, EXIT_FAILURE,
47
srand(), strtof(), abort() */
46
#include <stdlib.h> /* free(), EXIT_SUCCESS, srand(),
47
strtof(), abort() */
48
48
#include <stdbool.h> /* bool, false, true */
49
49
#include <string.h> /* memset(), strcmp(), strlen(),
50
50
strerror(), asprintf(), strcpy() */
82
82
#include <signal.h> /* sigemptyset(), sigaddset(),
83
83
sigaction(), SIGTERM, sig_atomic_t,
84
84
raise() */
85
#include <sysexits.h> /* EX_OSERR, EX_USAGE */
85
#include <sysexits.h> /* EX_OSERR, EX_USAGE, EX_UNAVAILABLE,
86
EX_NOHOST, EX_IOERR, EX_PROTOCOL */
86
87
87
88
#ifdef __linux__
88
89
#include <sys/klog.h> /* klogctl() */
126
127
static const char mandos_protocol_version[] = "1";
127
128
const char *argp_program_version = "mandos-client " VERSION;
128
129
const char *argp_program_bug_address = "<mandos@fukt.bsnet.se>";
130
static const char sys_class_net[] = "/sys/class/net";
131
char *connect_to = NULL;
129
132
130
133
/* Used for passing in values through the Avahi callback functions */
131
134
typedef struct {
553
556
gnutls_session_t session;
554
557
int pf; /* Protocol family */
555
558
559
errno = 0;
560
556
561
if(quit_now){
562
errno = EINTR;
557
563
return -1;
558
564
}
559
565
566
572
break;
567
573
default:
568
574
fprintf(stderr, "Bad address family: %d\n", af);
575
errno = EINVAL;
569
576
return -1;
570
577
}
571
578
581
588
582
589
tcp_sd = socket(pf, SOCK_STREAM, 0);
583
590
if(tcp_sd < 0){
591
int e = errno;
584
592
perror("socket");
593
errno = e;
585
594
goto mandos_end;
586
595
}
587
596
588
597
if(quit_now){
598
errno = EINTR;
589
599
goto mandos_end;
590
600
}
591
601
598
608
ret = inet_pton(af, ip, &to.in.sin_addr);
599
609
}
600
610
if(ret < 0 ){
611
int e = errno;
601
612
perror("inet_pton");
613
errno = e;
602
614
goto mandos_end;
603
615
}
604
616
if(ret == 0){
617
int e = errno;
605
618
fprintf(stderr, "Bad address: %s\n", ip);
619
errno = e;
606
620
goto mandos_end;
607
621
}
608
622
if(af == AF_INET6){
616
630
if(if_index == AVAHI_IF_UNSPEC){
617
631
fprintf(stderr, "An IPv6 link-local address is incomplete"
618
632
" without a network interface\n");
633
errno = EINVAL;
619
634
goto mandos_end;
620
635
}
621
636
/* Set the network interface number as scope */
628
643
}
629
644
630
645
if(quit_now){
646
errno = EINTR;
631
647
goto mandos_end;
632
648
}
633
649
664
680
}
665
681
666
682
if(quit_now){
683
errno = EINTR;
667
684
goto mandos_end;
668
685
}
669
686
673
690
ret = connect(tcp_sd, &to.in, sizeof(to)); /* IPv4 */
674
691
}
675
692
if(ret < 0){
693
int e = errno;
676
694
perror("connect");
695
errno = e;
677
696
goto mandos_end;
678
697
}
679
698
680
699
if(quit_now){
700
errno = EINTR;
681
701
goto mandos_end;
682
702
}
683
703
688
708
ret = (int)TEMP_FAILURE_RETRY(write(tcp_sd, out + written,
689
709
out_size - written));
690
710
if(ret == -1){
711
int e = errno;
691
712
perror("write");
713
errno = e;
692
714
goto mandos_end;
693
715
}
694
716
written += (size_t)ret;
704
726
}
705
727
706
728
if(quit_now){
729
errno = EINTR;
707
730
goto mandos_end;
708
731
}
709
732
}
713
736
}
714
737
715
738
if(quit_now){
739
errno = EINTR;
716
740
goto mandos_end;
717
741
}
718
742
719
743
gnutls_transport_set_ptr(session, (gnutls_transport_ptr_t) tcp_sd);
720
744
721
745
if(quit_now){
746
errno = EINTR;
722
747
goto mandos_end;
723
748
}
724
749
725
750
do {
726
751
ret = gnutls_handshake(session);
727
752
if(quit_now){
753
errno = EINTR;
728
754
goto mandos_end;
729
755
}
730
756
} while(ret == GNUTLS_E_AGAIN or ret == GNUTLS_E_INTERRUPTED);
734
760
fprintf(stderr, "*** GnuTLS Handshake failed ***\n");
735
761
gnutls_perror(ret);
736
762
}
763
errno = EPROTO;
737
764
goto mandos_end;
738
765
}
739
766
747
774
while(true){
748
775
749
776
if(quit_now){
777
errno = EINTR;
750
778
goto mandos_end;
751
779
}
752
780
753
781
buffer_capacity = incbuffer(&buffer, buffer_length,
754
782
buffer_capacity);
755
783
if(buffer_capacity == 0){
784
int e = errno;
756
785
perror("incbuffer");
786
errno = e;
757
787
goto mandos_end;
758
788
}
759
789
760
790
if(quit_now){
791
errno = EINTR;
761
792
goto mandos_end;
762
793
}
763
794
776
807
ret = gnutls_handshake(session);
777
808
778
809
if(quit_now){
810
errno = EINTR;
779
811
goto mandos_end;
780
812
}
781
813
} while(ret == GNUTLS_E_AGAIN or ret == GNUTLS_E_INTERRUPTED);
782
814
if(ret < 0){
783
815
fprintf(stderr, "*** GnuTLS Re-handshake failed ***\n");
784
816
gnutls_perror(ret);
817
errno = EPROTO;
785
818
goto mandos_end;
786
819
}
787
820
break;
789
822
fprintf(stderr, "Unknown error while reading data from"
790
823
" encrypted session with Mandos server\n");
791
824
gnutls_bye(session, GNUTLS_SHUT_RDWR);
825
errno = EIO;
792
826
goto mandos_end;
793
827
}
794
828
} else {
801
835
}
802
836
803
837
if(quit_now){
838
errno = EINTR;
804
839
goto mandos_end;
805
840
}
806
841
807
842
do {
808
843
ret = gnutls_bye(session, GNUTLS_SHUT_RDWR);
809
844
if(quit_now){
845
errno = EINTR;
810
846
goto mandos_end;
811
847
}
812
848
} while(ret == GNUTLS_E_AGAIN or ret == GNUTLS_E_INTERRUPTED);
821
857
written = 0;
822
858
while(written < (size_t) decrypted_buffer_size){
823
859
if(quit_now){
860
errno = EINTR;
824
861
goto mandos_end;
825
862
}
826
863
828
865
(size_t)decrypted_buffer_size - written,
829
866
stdout);
830
867
if(ret == 0 and ferror(stdout)){
868
int e = errno;
831
869
if(debug){
832
870
fprintf(stderr, "Error writing encrypted data: %s\n",
833
871
strerror(errno));
834
872
}
873
errno = e;
835
874
goto mandos_end;
836
875
}
837
876
written += (size_t)ret;
843
882
/* Shutdown procedure */
844
883
845
884
mandos_end:
846
free(decrypted_buffer);
847
free(buffer);
848
if(tcp_sd >= 0){
849
ret = (int)TEMP_FAILURE_RETRY(close(tcp_sd));
850
}
851
if(ret == -1){
852
perror("close");
853
}
854
gnutls_deinit(session);
855
if(quit_now){
856
retval = -1;
885
{
886
int e = errno;
887
free(decrypted_buffer);
888
free(buffer);
889
if(tcp_sd >= 0){
890
ret = (int)TEMP_FAILURE_RETRY(close(tcp_sd));
891
}
892
if(ret == -1){
893
if(e == 0){
894
e = errno;
895
}
896
perror("close");
897
}
898
gnutls_deinit(session);
899
if(quit_now){
900
e = EINTR;
901
retval = -1;
902
}
903
errno = e;
857
904
}
858
905
return retval;
859
906
}
975
1022
errno = old_errno;
976
1023
}
977
1024
1025
/*
1026
* This function determines if a directory entry in /sys/class/net
1027
* corresponds to an acceptable network device.
1028
* (This function is passed to scandir(3) as a filter function.)
1029
*/
1030
int good_interface(const struct dirent *if_entry){
1031
ssize_t ssret;
1032
char *flagname = NULL;
1033
int ret = asprintf(&flagname, "%s/%s/flags", sys_class_net,
1034
if_entry->d_name);
1035
if(ret < 0){
1036
perror("asprintf");
1037
return 0;
1038
}
1039
if(if_entry->d_name[0] == '.'){
1040
return 0;
1041
}
1042
int flags_fd = (int)TEMP_FAILURE_RETRY(open(flagname, O_RDONLY));
1043
if(flags_fd == -1){
1044
perror("open");
1045
return 0;
1046
}
1047
typedef short ifreq_flags; /* ifreq.ifr_flags in netdevice(7) */
1048
/* read line from flags_fd */
1049
ssize_t to_read = (sizeof(ifreq_flags)*2)+3; /* "0x1003\n" */
1050
char *flagstring = malloc((size_t)to_read+1); /* +1 for final \0 */
1051
flagstring[(size_t)to_read] = '\0';
1052
if(flagstring == NULL){
1053
perror("malloc");
1054
close(flags_fd);
1055
return 0;
1056
}
1057
while(to_read > 0){
1058
ssret = (ssize_t)TEMP_FAILURE_RETRY(read(flags_fd, flagstring,
1059
(size_t)to_read));
1060
if(ssret == -1){
1061
perror("read");
1062
free(flagstring);
1063
close(flags_fd);
1064
return 0;
1065
}
1066
to_read -= ssret;
1067
if(ssret == 0){
1068
break;
1069
}
1070
}
1071
close(flags_fd);
1072
intmax_t tmpmax;
1073
char *tmp;
1074
errno = 0;
1075
tmpmax = strtoimax(flagstring, &tmp, 0);
1076
if(errno != 0 or tmp == flagstring or (*tmp != '\0'
1077
and not (isspace(*tmp)))
1078
or tmpmax != (ifreq_flags)tmpmax){
1079
if(debug){
1080
fprintf(stderr, "Invalid flags \"%s\" for interface \"%s\"\n",
1081
flagstring, if_entry->d_name);
1082
}
1083
free(flagstring);
1084
return 0;
1085
}
1086
free(flagstring);
1087
ifreq_flags flags = (ifreq_flags)tmpmax;
1088
/* Reject the loopback device */
1089
if(flags & IFF_LOOPBACK){
1090
if(debug){
1091
fprintf(stderr, "Rejecting loopback interface \"%s\"\n",
1092
if_entry->d_name);
1093
}
1094
return 0;
1095
}
1096
/* Accept point-to-point devices only if connect_to is specified */
1097
if(connect_to != NULL and (flags & IFF_POINTOPOINT)){
1098
if(debug){
1099
fprintf(stderr, "Accepting point-to-point interface \"%s\"\n",
1100
if_entry->d_name);
1101
}
1102
return 1;
1103
}
1104
/* Otherwise, reject non-broadcast-capable devices */
1105
if(not (flags & IFF_BROADCAST)){
1106
if(debug){
1107
fprintf(stderr, "Rejecting non-broadcast interface \"%s\"\n",
1108
if_entry->d_name);
1109
}
1110
return 0;
1111
}
1112
/* Accept this device */
1113
if(debug){
1114
fprintf(stderr, "Interface \"%s\" is acceptable\n",
1115
if_entry->d_name);
1116
}
1117
return 1;
1118
}
1119
978
1120
int main(int argc, char *argv[]){
979
1121
AvahiSServiceBrowser *sb = NULL;
980
1122
int error;
982
1124
intmax_t tmpmax;
983
1125
char *tmp;
984
1126
int exitcode = EXIT_SUCCESS;
985
const char *interface = "eth0";
1127
const char *interface = "";
986
1128
struct ifreq network;
987
1129
int sd = -1;
988
1130
bool take_down_interface = false;
989
1131
uid_t uid;
990
1132
gid_t gid;
991
char *connect_to = NULL;
992
1133
char tempdir[] = "/tmp/mandosXXXXXX";
993
1134
bool tempdir_created = false;
994
1135
AvahiIfIndex if_index = AVAHI_IF_UNSPEC;
1151
1292
if(not debug){
1152
1293
avahi_set_log_function(empty_log);
1153
1294
}
1295
1296
if(interface[0] == '\0'){
1297
struct dirent **direntries;
1298
ret = scandir(sys_class_net, &direntries, good_interface,
1299
alphasort);
1300
if(ret >= 1){
1301
/* Pick the first good interface */
1302
interface = strdup(direntries[0]->d_name);
1303
if(debug){
1304
fprintf(stderr, "Using interface \"%s\"\n", interface);
1305
}
1306
if(interface == NULL){
1307
perror("malloc");
1308
free(direntries);
1309
exitcode = EXIT_FAILURE;
1310
goto end;
1311
}
1312
free(direntries);
1313
} else {
1314
free(direntries);
1315
fprintf(stderr, "Could not find a network interface\n");
1316
exitcode = EXIT_FAILURE;
1317
goto end;
1318
}
1319
}
1154
1320
1155
1321
/* Initialize Avahi early so avahi_simple_poll_quit() can be called
1156
1322
from the signal handler */
1159
1325
mc.simple_poll = avahi_simple_poll_new();
1160
1326
if(mc.simple_poll == NULL){
1161
1327
fprintf(stderr, "Avahi: Failed to create simple poll object.\n");
1162
exitcode = EXIT_FAILURE;
1328
exitcode = EX_UNAVAILABLE;
1163
1329
goto end;
1164
1330
}
1165
1331
1167
1333
ret = sigaddset(&sigterm_action.sa_mask, SIGINT);
1168
1334
if(ret == -1){
1169
1335
perror("sigaddset");
1170
exitcode = EXIT_FAILURE;
1336
exitcode = EX_OSERR;
1171
1337
goto end;
1172
1338
}
1173
1339
ret = sigaddset(&sigterm_action.sa_mask, SIGHUP);
1174
1340
if(ret == -1){
1175
1341
perror("sigaddset");
1176
exitcode = EXIT_FAILURE;
1342
exitcode = EX_OSERR;
1177
1343
goto end;
1178
1344
}
1179
1345
ret = sigaddset(&sigterm_action.sa_mask, SIGTERM);
1180
1346
if(ret == -1){
1181
1347
perror("sigaddset");
1182
exitcode = EXIT_FAILURE;
1348
exitcode = EX_OSERR;
1183
1349
goto end;
1184
1350
}
1185
1351
/* Need to check if the handler is SIG_IGN before handling:
1189
1355
ret = sigaction(SIGINT, NULL, &old_sigterm_action);
1190
1356
if(ret == -1){
1191
1357
perror("sigaction");
1192
return EXIT_FAILURE;
1358
return EX_OSERR;
1193
1359
}
1194
1360
if(old_sigterm_action.sa_handler != SIG_IGN){
1195
1361
ret = sigaction(SIGINT, &sigterm_action, NULL);
1196
1362
if(ret == -1){
1197
1363
perror("sigaction");
1198
exitcode = EXIT_FAILURE;
1364
exitcode = EX_OSERR;
1199
1365
goto end;
1200
1366
}
1201
1367
}
1202
1368
ret = sigaction(SIGHUP, NULL, &old_sigterm_action);
1203
1369
if(ret == -1){
1204
1370
perror("sigaction");
1205
return EXIT_FAILURE;
1371
return EX_OSERR;
1206
1372
}
1207
1373
if(old_sigterm_action.sa_handler != SIG_IGN){
1208
1374
ret = sigaction(SIGHUP, &sigterm_action, NULL);
1209
1375
if(ret == -1){
1210
1376
perror("sigaction");
1211
exitcode = EXIT_FAILURE;
1377
exitcode = EX_OSERR;
1212
1378
goto end;
1213
1379
}
1214
1380
}
1215
1381
ret = sigaction(SIGTERM, NULL, &old_sigterm_action);
1216
1382
if(ret == -1){
1217
1383
perror("sigaction");
1218
return EXIT_FAILURE;
1384
return EX_OSERR;
1219
1385
}
1220
1386
if(old_sigterm_action.sa_handler != SIG_IGN){
1221
1387
ret = sigaction(SIGTERM, &sigterm_action, NULL);
1222
1388
if(ret == -1){
1223
1389
perror("sigaction");
1224
exitcode = EXIT_FAILURE;
1390
exitcode = EX_OSERR;
1225
1391
goto end;
1226
1392
}
1227
1393
}
1228
1394
1229
1395
/* If the interface is down, bring it up */
1230
if(interface[0] != '\0'){
1396
if(strcmp(interface, "none") != 0){
1231
1397
if_index = (AvahiIfIndex) if_nametoindex(interface);
1232
1398
if(if_index == 0){
1233
1399
fprintf(stderr, "No such interface: \"%s\"\n", interface);
1234
exitcode = EXIT_FAILURE;
1400
exitcode = EX_UNAVAILABLE;
1235
1401
goto end;
1236
1402
}
1237
1403
1260
1426
sd = socket(PF_INET6, SOCK_DGRAM, IPPROTO_IP);
1261
1427
if(sd < 0){
1262
1428
perror("socket");
1263
exitcode = EXIT_FAILURE;
1429
exitcode = EX_OSERR;
1264
1430
#ifdef __linux__
1265
1431
if(restore_loglevel){
1266
1432
ret = klogctl(7, NULL, 0);
1289
1455
}
1290
1456
}
1291
1457
#endif /* __linux__ */
1292
exitcode = EXIT_FAILURE;
1458
exitcode = EX_OSERR;
1293
1459
/* Lower privileges */
1294
1460
errno = 0;
1295
1461
ret = seteuid(uid);
1304
1470
ret = ioctl(sd, SIOCSIFFLAGS, &network);
1305
1471
if(ret == -1){
1306
1472
take_down_interface = false;
1307
perror("ioctl SIOCSIFFLAGS");
1308
exitcode = EXIT_FAILURE;
1473
perror("ioctl SIOCSIFFLAGS +IFF_UP");
1474
exitcode = EX_OSERR;
1309
1475
#ifdef __linux__
1310
1476
if(restore_loglevel){
1311
1477
ret = klogctl(7, NULL, 0);
1377
1543
ret = init_gnutls_global(pubkey, seckey);
1378
1544
if(ret == -1){
1379
1545
fprintf(stderr, "init_gnutls_global failed\n");
1380
exitcode = EXIT_FAILURE;
1546
exitcode = EX_UNAVAILABLE;
1381
1547
goto end;
1382
1548
} else {
1383
1549
gnutls_initialized = true;
1400
1566
1401
1567
if(not init_gpgme(pubkey, seckey, tempdir)){
1402
1568
fprintf(stderr, "init_gpgme failed\n");
1403
exitcode = EXIT_FAILURE;
1569
exitcode = EX_UNAVAILABLE;
1404
1570
goto end;
1405
1571
} else {
1406
1572
gpgme_initialized = true;
1416
1582
char *address = strrchr(connect_to, ':');
1417
1583
if(address == NULL){
1418
1584
fprintf(stderr, "No colon in address\n");
1419
exitcode = EXIT_FAILURE;
1585
exitcode = EX_USAGE;
1420
1586
goto end;
1421
1587
}
1422
1588
1430
1596
if(errno != 0 or tmp == address+1 or *tmp != '\0'
1431
1597
or tmpmax != (uint16_t)tmpmax){
1432
1598
fprintf(stderr, "Bad port number\n");
1433
exitcode = EXIT_FAILURE;
1599
exitcode = EX_USAGE;
1434
1600
goto end;
1435
1601
}
1436
1602
1455
1621
1456
1622
ret = start_mandos_communication(address, port, if_index, af);
1457
1623
if(ret < 0){
1458
exitcode = EXIT_FAILURE;
1624
switch(errno){
1625
case ENETUNREACH:
1626
case EHOSTDOWN:
1627
case EHOSTUNREACH:
1628
exitcode = EX_NOHOST;
1629
break;
1630
case EINVAL:
1631
exitcode = EX_USAGE;
1632
break;
1633
case EIO:
1634
exitcode = EX_IOERR;
1635
break;
1636
case EPROTO:
1637
exitcode = EX_PROTOCOL;
1638
break;
1639
default:
1640
exitcode = EX_OSERR;
1641
break;
1642
}
1459
1643
} else {
1460
1644
exitcode = EXIT_SUCCESS;
1461
1645
}
1488
1672
if(mc.server == NULL){
1489
1673
fprintf(stderr, "Failed to create Avahi server: %s\n",
1490
1674
avahi_strerror(error));
1491
exitcode = EXIT_FAILURE;
1675
exitcode = EX_UNAVAILABLE;
1492
1676
goto end;
1493
1677
}
1494
1678
1503
1687
if(sb == NULL){
1504
1688
fprintf(stderr, "Failed to create service browser: %s\n",
1505
1689
avahi_strerror(avahi_server_errno(mc.server)));
1506
exitcode = EXIT_FAILURE;
1690
exitcode = EX_UNAVAILABLE;
1507
1691
goto end;
1508
1692
}
1509
1693
1561
1745
network.ifr_flags &= ~(short)IFF_UP; /* clear flag */
1562
1746
ret = ioctl(sd, SIOCSIFFLAGS, &network);
1563
1747
if(ret == -1){
1564
perror("ioctl SIOCSIFFLAGS");
1748
perror("ioctl SIOCSIFFLAGS -IFF_UP");
1565
1749
}
1566
1750
}
1567
1751
ret = (int)TEMP_FAILURE_RETRY(close(sd));
Loggerhead is a web-based interface for Breezy
Version: 2.0.2.dev0