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 768
- compare with another revision
- download diff
- download tarball
- view history from revision 768
- Committer: Teddy Hogeborn
- Date: 2015-07-12 01:25:14 UTC
- Revision ID: teddy@recompile.se-20150712012514-x4wdgi1hz46h0apg
debian/mandos-client.README.Debian: Document the dhparams.pem file.
added
removed
plugins.d/mandos-client.c
9
9
* "browse_callback", and parts of "main".
10
10
*
11
11
* Everything else is
12
* Copyright © 2008-2016 Teddy Hogeborn
13
* Copyright © 2008-2016 Björn Påhlsson
12
* Copyright © 2008-2015 Teddy Hogeborn
13
* Copyright © 2008-2015 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
46
46
#include <stdlib.h> /* free(), EXIT_SUCCESS, srand(),
47
47
strtof(), abort() */
48
48
#include <stdbool.h> /* bool, false, true */
49
#include <string.h> /* strcmp(), strlen(), strerror(),
50
asprintf(), strncpy() */
49
#include <string.h> /* memset(), strcmp(), strlen(),
50
strerror(), asprintf(), strcpy() */
51
51
#include <sys/ioctl.h> /* ioctl */
52
52
#include <sys/types.h> /* socket(), inet_pton(), sockaddr,
53
53
sockaddr_in6, PF_INET6,
57
57
#include <sys/socket.h> /* socket(), struct sockaddr_in6,
58
58
inet_pton(), connect(),
59
59
getnameinfo() */
60
#include <fcntl.h> /* open(), unlinkat(), AT_REMOVEDIR */
60
#include <fcntl.h> /* open(), unlinkat() */
61
61
#include <dirent.h> /* opendir(), struct dirent, readdir()
62
62
*/
63
63
#include <inttypes.h> /* PRIu16, PRIdMAX, intmax_t,
64
64
strtoimax() */
65
#include <errno.h> /* perror(), errno, EINTR, EINVAL,
66
EAI_SYSTEM, ENETUNREACH,
67
EHOSTUNREACH, ECONNREFUSED, EPROTO,
68
EIO, ENOENT, ENXIO, ENOMEM, EISDIR,
69
ENOTEMPTY,
65
#include <errno.h> /* perror(), errno,
70
66
program_invocation_short_name */
71
67
#include <time.h> /* nanosleep(), time(), sleep() */
72
68
#include <net/if.h> /* ioctl, ifreq, SIOCGIFFLAGS, IFF_UP,
309
305
return false;
310
306
}
311
307
312
ret = close(fd);
308
ret = (int)TEMP_FAILURE_RETRY(close(fd));
313
309
if(ret == -1){
314
310
perror_plus("close");
315
311
}
517
513
fprintf_plus(stderr, "GnuTLS: %s", string);
518
514
}
519
515
520
__attribute__((nonnull(1, 2, 4), warn_unused_result))
516
__attribute__((nonnull, warn_unused_result))
521
517
static int init_gnutls_global(const char *pubkeyfilename,
522
518
const char *seckeyfilename,
523
519
const char *dhparamsfilename,
529
525
fprintf_plus(stderr, "Initializing GnuTLS\n");
530
526
}
531
527
528
ret = gnutls_global_init();
529
if(ret != GNUTLS_E_SUCCESS){
530
fprintf_plus(stderr, "GnuTLS global_init: %s\n",
531
safer_gnutls_strerror(ret));
532
return -1;
533
}
534
532
535
if(debug){
533
536
/* "Use a log level over 10 to enable all debugging options."
534
537
* - GnuTLS manual
542
545
if(ret != GNUTLS_E_SUCCESS){
543
546
fprintf_plus(stderr, "GnuTLS memory error: %s\n",
544
547
safer_gnutls_strerror(ret));
548
gnutls_global_deinit();
545
549
return -1;
546
550
}
547
551
751
755
globalfail:
752
756
753
757
gnutls_certificate_free_credentials(mc->cred);
758
gnutls_global_deinit();
754
759
gnutls_dh_params_deinit(mc->dh_params);
755
760
return -1;
756
761
}
817
822
818
823
/* Set effective uid to 0, return errno */
819
824
__attribute__((warn_unused_result))
820
int raise_privileges(void){
821
int old_errno = errno;
822
int ret = 0;
825
error_t raise_privileges(void){
826
error_t old_errno = errno;
827
error_t ret_errno = 0;
823
828
if(seteuid(0) == -1){
824
ret = errno;
829
ret_errno = errno;
825
830
}
826
831
errno = old_errno;
827
return ret;
832
return ret_errno;
828
833
}
829
834
830
835
/* Set effective and real user ID to 0. Return errno. */
831
836
__attribute__((warn_unused_result))
832
int raise_privileges_permanently(void){
833
int old_errno = errno;
834
int ret = raise_privileges();
835
if(ret != 0){
837
error_t raise_privileges_permanently(void){
838
error_t old_errno = errno;
839
error_t ret_errno = raise_privileges();
840
if(ret_errno != 0){
836
841
errno = old_errno;
837
return ret;
842
return ret_errno;
838
843
}
839
844
if(setuid(0) == -1){
840
ret = errno;
845
ret_errno = errno;
841
846
}
842
847
errno = old_errno;
843
return ret;
848
return ret_errno;
844
849
}
845
850
846
851
/* Set effective user ID to unprivileged saved user ID */
847
852
__attribute__((warn_unused_result))
848
int lower_privileges(void){
849
int old_errno = errno;
850
int ret = 0;
853
error_t lower_privileges(void){
854
error_t old_errno = errno;
855
error_t ret_errno = 0;
851
856
if(seteuid(uid) == -1){
852
ret = errno;
857
ret_errno = errno;
853
858
}
854
859
errno = old_errno;
855
return ret;
860
return ret_errno;
856
861
}
857
862
858
863
/* Lower privileges permanently */
859
864
__attribute__((warn_unused_result))
860
int lower_privileges_permanently(void){
861
int old_errno = errno;
862
int ret = 0;
865
error_t lower_privileges_permanently(void){
866
error_t old_errno = errno;
867
error_t ret_errno = 0;
863
868
if(setuid(uid) == -1){
864
ret = errno;
869
ret_errno = errno;
865
870
}
866
871
errno = old_errno;
867
return ret;
872
return ret_errno;
868
873
}
869
874
870
875
/* Helper function to add_local_route() and delete_local_route() */
926
931
perror_plus("dup2(devnull, STDIN_FILENO)");
927
932
_exit(EX_OSERR);
928
933
}
929
ret = close(devnull);
934
ret = (int)TEMP_FAILURE_RETRY(close(devnull));
930
935
if(ret == -1){
931
936
perror_plus("close");
932
937
_exit(EX_OSERR);
949
954
helper, O_RDONLY));
950
955
if(helper_fd == -1){
951
956
perror_plus("openat");
952
close(helperdir_fd);
953
957
_exit(EX_UNAVAILABLE);
954
958
}
955
close(helperdir_fd);
959
TEMP_FAILURE_RETRY(close(helperdir_fd));
956
960
#ifdef __GNUC__
957
961
#pragma GCC diagnostic push
958
962
#pragma GCC diagnostic ignored "-Wcast-qual"
1126
1130
goto mandos_end;
1127
1131
}
1128
1132
1133
memset(&to, 0, sizeof(to));
1129
1134
if(af == AF_INET6){
1130
struct sockaddr_in6 *to6 = (struct sockaddr_in6 *)&to;
1131
*to6 = (struct sockaddr_in6){ .sin6_family = (sa_family_t)af };
1132
ret = inet_pton(af, ip, &to6->sin6_addr);
1135
((struct sockaddr_in6 *)&to)->sin6_family = (sa_family_t)af;
1136
ret = inet_pton(af, ip, &((struct sockaddr_in6 *)&to)->sin6_addr);
1133
1137
} else { /* IPv4 */
1134
struct sockaddr_in *to4 = (struct sockaddr_in *)&to;
1135
*to4 = (struct sockaddr_in){ .sin_family = (sa_family_t)af };
1136
ret = inet_pton(af, ip, &to4->sin_addr);
1138
((struct sockaddr_in *)&to)->sin_family = (sa_family_t)af;
1139
ret = inet_pton(af, ip, &((struct sockaddr_in *)&to)->sin_addr);
1137
1140
}
1138
1141
if(ret < 0 ){
1139
1142
int e = errno;
1218
1221
sizeof(struct sockaddr_in));
1219
1222
}
1220
1223
if(ret < 0){
1221
if(((errno == ENETUNREACH) or (errno == EHOSTUNREACH))
1224
if(errno == ENETUNREACH
1222
1225
and if_index != AVAHI_IF_UNSPEC
1223
1226
and connect_to == NULL
1224
1227
and not route_added and
1462
1465
free(decrypted_buffer);
1463
1466
free(buffer);
1464
1467
if(tcp_sd >= 0){
1465
ret = close(tcp_sd);
1468
ret = (int)TEMP_FAILURE_RETRY(close(tcp_sd));
1466
1469
}
1467
1470
if(ret == -1){
1468
1471
if(e == 0){
1623
1626
__attribute__((nonnull, warn_unused_result))
1624
1627
bool get_flags(const char *ifname, struct ifreq *ifr){
1625
1628
int ret;
1626
int old_errno;
1629
error_t ret_errno;
1627
1630
1628
1631
int s = socket(PF_INET6, SOCK_DGRAM, IPPROTO_IP);
1629
1632
if(s < 0){
1630
old_errno = errno;
1633
ret_errno = errno;
1631
1634
perror_plus("socket");
1632
errno = old_errno;
1635
errno = ret_errno;
1633
1636
return false;
1634
1637
}
1635
strncpy(ifr->ifr_name, ifname, IF_NAMESIZE);
1636
ifr->ifr_name[IF_NAMESIZE-1] = '\0'; /* NUL terminate */
1638
strcpy(ifr->ifr_name, ifname);
1637
1639
ret = ioctl(s, SIOCGIFFLAGS, ifr);
1638
1640
if(ret == -1){
1639
1641
if(debug){
1640
old_errno = errno;
1642
ret_errno = errno;
1641
1643
perror_plus("ioctl SIOCGIFFLAGS");
1642
errno = old_errno;
1644
errno = ret_errno;
1643
1645
}
1644
1646
return false;
1645
1647
}
1909
1911
return;
1910
1912
}
1911
1913
}
1914
#ifdef __GLIBC__
1915
#if __GLIBC_PREREQ(2, 15)
1912
1916
int numhooks = scandirat(hookdir_fd, ".", &direntries,
1913
1917
runnable_hook, alphasort);
1918
#else /* not __GLIBC_PREREQ(2, 15) */
1919
int numhooks = scandir(hookdir, &direntries, runnable_hook,
1920
alphasort);
1921
#endif /* not __GLIBC_PREREQ(2, 15) */
1922
#else /* not __GLIBC__ */
1923
int numhooks = scandir(hookdir, &direntries, runnable_hook,
1924
alphasort);
1925
#endif /* not __GLIBC__ */
1914
1926
if(numhooks == -1){
1915
1927
perror_plus("scandir");
1916
1928
return;
1998
2010
perror_plus("openat");
1999
2011
_exit(EXIT_FAILURE);
2000
2012
}
2001
if(close(hookdir_fd) == -1){
2013
if((int)TEMP_FAILURE_RETRY(close(hookdir_fd)) == -1){
2002
2014
perror_plus("close");
2003
2015
_exit(EXIT_FAILURE);
2004
2016
}
2007
2019
perror_plus("dup2(devnull, STDIN_FILENO)");
2008
2020
_exit(EX_OSERR);
2009
2021
}
2010
ret = close(devnull);
2022
ret = (int)TEMP_FAILURE_RETRY(close(devnull));
2011
2023
if(ret == -1){
2012
2024
perror_plus("close");
2013
2025
_exit(EX_OSERR);
2062
2074
free(direntry);
2063
2075
}
2064
2076
free(direntries);
2065
if(close(hookdir_fd) == -1){
2077
if((int)TEMP_FAILURE_RETRY(close(hookdir_fd)) == -1){
2066
2078
perror_plus("close");
2067
2079
} else {
2068
2080
hookdir_fd = -1;
2071
2083
}
2072
2084
2073
2085
__attribute__((nonnull, warn_unused_result))
2074
int bring_up_interface(const char *const interface,
2075
const float delay){
2076
int old_errno = errno;
2086
error_t bring_up_interface(const char *const interface,
2087
const float delay){
2088
error_t old_errno = errno;
2077
2089
int ret;
2078
2090
struct ifreq network;
2079
2091
unsigned int if_index = if_nametoindex(interface);
2089
2101
}
2090
2102
2091
2103
if(not interface_is_up(interface)){
2092
int ret_errno = 0;
2093
int ioctl_errno = 0;
2104
error_t ret_errno = 0, ioctl_errno = 0;
2094
2105
if(not get_flags(interface, &network)){
2095
2106
ret_errno = errno;
2096
2107
fprintf_plus(stderr, "Failed to get flags for interface "
2109
2120
}
2110
2121
2111
2122
if(quit_now){
2112
ret = close(sd);
2123
ret = (int)TEMP_FAILURE_RETRY(close(sd));
2113
2124
if(ret == -1){
2114
2125
perror_plus("close");
2115
2126
}
2165
2176
}
2166
2177
2167
2178
/* Close the socket */
2168
ret = close(sd);
2179
ret = (int)TEMP_FAILURE_RETRY(close(sd));
2169
2180
if(ret == -1){
2170
2181
perror_plus("close");
2171
2182
}
2199
2210
}
2200
2211
2201
2212
__attribute__((nonnull, warn_unused_result))
2202
int take_down_interface(const char *const interface){
2203
int old_errno = errno;
2213
error_t take_down_interface(const char *const interface){
2214
error_t old_errno = errno;
2204
2215
struct ifreq network;
2205
2216
unsigned int if_index = if_nametoindex(interface);
2206
2217
if(if_index == 0){
2209
2220
return ENXIO;
2210
2221
}
2211
2222
if(interface_is_up(interface)){
2212
int ret_errno = 0;
2213
int ioctl_errno = 0;
2223
error_t ret_errno = 0, ioctl_errno = 0;
2214
2224
if(not get_flags(interface, &network) and debug){
2215
2225
ret_errno = errno;
2216
2226
fprintf_plus(stderr, "Failed to get flags for interface "
2254
2264
}
2255
2265
2256
2266
/* Close the socket */
2257
int ret = close(sd);
2267
int ret = (int)TEMP_FAILURE_RETRY(close(sd));
2258
2268
if(ret == -1){
2259
2269
perror_plus("close");
2260
2270
}
2276
2286
2277
2287
int main(int argc, char *argv[]){
2278
2288
mandos_context mc = { .server = NULL, .dh_bits = 0,
2279
.priority = "SECURE256:!CTYPE-X.509"
2280
":+CTYPE-OPENPGP:!RSA:+SIGN-DSA-SHA256",
2281
.current_server = NULL, .interfaces = NULL,
2282
.interfaces_size = 0 };
2289
.priority = "SECURE256:!CTYPE-X.509:"
2290
"+CTYPE-OPENPGP:!RSA", .current_server = NULL,
2291
.interfaces = NULL, .interfaces_size = 0 };
2283
2292
AvahiSServiceBrowser *sb = NULL;
2284
2293
error_t ret_errno;
2285
2294
int ret;
2466
2475
.args_doc = "",
2467
2476
.doc = "Mandos client -- Get and decrypt"
2468
2477
" passwords from a Mandos server" };
2469
ret_errno = argp_parse(&argp, argc, argv,
2470
ARGP_IN_ORDER | ARGP_NO_HELP, 0, NULL);
2471
switch(ret_errno){
2478
ret = argp_parse(&argp, argc, argv,
2479
ARGP_IN_ORDER | ARGP_NO_HELP, 0, NULL);
2480
switch(ret){
2472
2481
case 0:
2473
2482
break;
2474
2483
case ENOMEM:
2475
2484
default:
2476
errno = ret_errno;
2485
errno = ret;
2477
2486
perror_plus("argp_parse");
2478
2487
exitcode = EX_OSERR;
2479
2488
goto end;
2488
2497
<http://bugs.debian.org/633582> */
2489
2498
2490
2499
/* Re-raise privileges */
2491
ret = raise_privileges();
2492
if(ret != 0){
2493
errno = ret;
2500
ret_errno = raise_privileges();
2501
if(ret_errno != 0){
2502
errno = ret_errno;
2494
2503
perror_plus("Failed to raise privileges");
2495
2504
} else {
2496
2505
struct stat st;
2512
2521
}
2513
2522
}
2514
2523
}
2515
close(seckey_fd);
2524
TEMP_FAILURE_RETRY(close(seckey_fd));
2516
2525
}
2517
2526
}
2518
2527
2533
2542
}
2534
2543
}
2535
2544
}
2536
close(pubkey_fd);
2545
TEMP_FAILURE_RETRY(close(pubkey_fd));
2537
2546
}
2538
2547
}
2539
2548
2540
if(dh_params_file != NULL
2541
and strcmp(dh_params_file, PATHDIR "/dhparams.pem" ) == 0){
2549
if(strcmp(dh_params_file, PATHDIR "/dhparams.pem" ) == 0){
2542
2550
int dhparams_fd = open(dh_params_file, O_RDONLY);
2543
2551
if(dhparams_fd == -1){
2544
2552
perror_plus("open");
2555
2563
}
2556
2564
}
2557
2565
}
2558
close(dhparams_fd);
2566
TEMP_FAILURE_RETRY(close(dhparams_fd));
2559
2567
}
2560
2568
}
2561
2569
2562
2570
/* Lower privileges */
2563
ret = lower_privileges();
2564
if(ret != 0){
2565
errno = ret;
2571
ret_errno = lower_privileges();
2572
if(ret_errno != 0){
2573
errno = ret_errno;
2566
2574
perror_plus("Failed to lower privileges");
2567
2575
}
2568
2576
}
2896
2904
2897
2905
/* Allocate a new server */
2898
2906
mc.server = avahi_server_new(avahi_simple_poll_get(simple_poll),
2899
&config, NULL, NULL, &ret);
2907
&config, NULL, NULL, &ret_errno);
2900
2908
2901
2909
/* Free the Avahi configuration data */
2902
2910
avahi_server_config_free(&config);
2905
2913
/* Check if creating the Avahi server object succeeded */
2906
2914
if(mc.server == NULL){
2907
2915
fprintf_plus(stderr, "Failed to create Avahi server: %s\n",
2908
avahi_strerror(ret));
2916
avahi_strerror(ret_errno));
2909
2917
exitcode = EX_UNAVAILABLE;
2910
2918
goto end;
2911
2919
}
2963
2971
2964
2972
if(gnutls_initialized){
2965
2973
gnutls_certificate_free_credentials(mc.cred);
2974
gnutls_global_deinit();
2966
2975
gnutls_dh_params_deinit(mc.dh_params);
2967
2976
}
2968
2977
2991
3000
2992
3001
/* Re-raise privileges */
2993
3002
{
2994
ret = raise_privileges();
2995
if(ret != 0){
2996
errno = ret;
3003
ret_errno = raise_privileges();
3004
if(ret_errno != 0){
3005
errno = ret_errno;
2997
3006
perror_plus("Failed to raise privileges");
2998
3007
} else {
2999
3008
3007
3016
while((interface=argz_next(interfaces_to_take_down,
3008
3017
interfaces_to_take_down_size,
3009
3018
interface))){
3010
ret = take_down_interface(interface);
3011
if(ret != 0){
3012
errno = ret;
3019
ret_errno = take_down_interface(interface);
3020
if(ret_errno != 0){
3021
errno = ret_errno;
3013
3022
perror_plus("Failed to take down interface");
3014
3023
}
3015
3024
}
3020
3029
}
3021
3030
}
3022
3031
3023
ret = lower_privileges_permanently();
3024
if(ret != 0){
3025
errno = ret;
3032
ret_errno = lower_privileges_permanently();
3033
if(ret_errno != 0){
3034
errno = ret_errno;
3026
3035
perror_plus("Failed to lower privileges permanently");
3027
3036
}
3028
3037
}
3030
3039
free(interfaces_to_take_down);
3031
3040
free(interfaces_hooks);
3032
3041
3033
void clean_dir_at(int base, const char * const dirname,
3034
uintmax_t level){
3035
struct dirent **direntries = NULL;
3036
int dret;
3037
int dir_fd = (int)TEMP_FAILURE_RETRY(openat(base, dirname,
3038
O_RDONLY
3039
| O_NOFOLLOW
3040
| O_DIRECTORY
3041
| O_PATH));
3042
if(dir_fd == -1){
3043
perror_plus("open");
3044
}
3045
int numentries = scandirat(dir_fd, ".", &direntries,
3046
notdotentries, alphasort);
3047
if(numentries >= 0){
3048
for(int i = 0; i < numentries; i++){
3049
if(debug){
3050
fprintf_plus(stderr, "Unlinking \"%s/%s\"\n",
3051
dirname, direntries[i]->d_name);
3052
}
3053
dret = unlinkat(dir_fd, direntries[i]->d_name, 0);
3054
if(dret == -1){
3055
if(errno == EISDIR){
3056
dret = unlinkat(dir_fd, direntries[i]->d_name,
3057
AT_REMOVEDIR);
3058
}
3059
if((dret == -1) and (errno == ENOTEMPTY)
3060
and (strcmp(direntries[i]->d_name, "private-keys-v1.d")
3061
== 0) and (level == 0)){
3062
/* Recurse only in this special case */
3063
clean_dir_at(dir_fd, direntries[i]->d_name, level+1);
3064
dret = 0;
3065
}
3066
if(dret == -1){
3067
fprintf_plus(stderr, "unlink(\"%s/%s\"): %s\n", dirname,
3068
direntries[i]->d_name, strerror(errno));
3069
}
3070
}
3071
free(direntries[i]);
3072
}
3073
3074
/* need to clean even if 0 because man page doesn't specify */
3075
free(direntries);
3076
if(numentries == -1){
3077
perror_plus("scandirat");
3078
}
3079
dret = unlinkat(base, dirname, AT_REMOVEDIR);
3080
if(dret == -1 and errno != ENOENT){
3081
perror_plus("rmdir");
3082
}
3083
} else {
3084
perror_plus("scandirat");
3085
}
3086
close(dir_fd);
3087
}
3088
3089
3042
/* Removes the GPGME temp directory and all files inside */
3090
3043
if(tempdir != NULL){
3091
clean_dir_at(-1, tempdir, 0);
3044
struct dirent **direntries = NULL;
3045
int tempdir_fd = (int)TEMP_FAILURE_RETRY(open(tempdir, O_RDONLY
3046
| O_NOFOLLOW
3047
| O_DIRECTORY
3048
| O_PATH));
3049
if(tempdir_fd == -1){
3050
perror_plus("open");
3051
} else {
3052
#ifdef __GLIBC__
3053
#if __GLIBC_PREREQ(2, 15)
3054
int numentries = scandirat(tempdir_fd, ".", &direntries,
3055
notdotentries, alphasort);
3056
#else /* not __GLIBC_PREREQ(2, 15) */
3057
int numentries = scandir(tempdir, &direntries, notdotentries,
3058
alphasort);
3059
#endif /* not __GLIBC_PREREQ(2, 15) */
3060
#else /* not __GLIBC__ */
3061
int numentries = scandir(tempdir, &direntries, notdotentries,
3062
alphasort);
3063
#endif /* not __GLIBC__ */
3064
if(numentries >= 0){
3065
for(int i = 0; i < numentries; i++){
3066
ret = unlinkat(tempdir_fd, direntries[i]->d_name, 0);
3067
if(ret == -1){
3068
fprintf_plus(stderr, "unlinkat(open(\"%s\", O_RDONLY),"
3069
" \"%s\", 0): %s\n", tempdir,
3070
direntries[i]->d_name, strerror(errno));
3071
}
3072
free(direntries[i]);
3073
}
3074
3075
/* need to clean even if 0 because man page doesn't specify */
3076
free(direntries);
3077
if(numentries == -1){
3078
perror_plus("scandir");
3079
}
3080
ret = rmdir(tempdir);
3081
if(ret == -1 and errno != ENOENT){
3082
perror_plus("rmdir");
3083
}
3084
}
3085
TEMP_FAILURE_RETRY(close(tempdir_fd));
3086
}
3092
3087
}
3093
3088
3094
3089
if(quit_now){
Loggerhead is a web-based interface for Breezy
Version: 2.0.2.dev0