137
137
bool debug = false;
138
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>";
139
const char *argp_program_version = "mandos-client " VERSION;
140
const char *argp_program_bug_address = "<mandos@recompile.se>";
141
141
static const char sys_class_net[] = "/sys/class/net";
142
142
char *connect_to = NULL;
143
143
const char *hookdir = HOOKDIR;
183
183
perror(print_text);
186
__attribute__((format (gnu_printf, 2, 3), nonnull))
186
__attribute__((format (gnu_printf, 2, 3)))
187
187
int fprintf_plus(FILE *stream, const char *format, ...){
189
189
va_start (ap, format);
198
198
* bytes. "buffer_capacity" is how much is currently allocated,
199
199
* "buffer_length" is how much is already used.
201
__attribute__((nonnull, warn_unused_result))
202
201
size_t incbuffer(char **buffer, size_t buffer_length,
203
202
size_t buffer_capacity){
204
203
if(buffer_length + BUFFER_SIZE > buffer_capacity){
219
218
/* Add server to set of servers to retry periodically */
220
__attribute__((nonnull, warn_unused_result))
221
219
bool add_server(const char *ip, in_port_t port, AvahiIfIndex if_index,
222
220
int af, server **current_server){
244
242
new_server->next = new_server;
245
243
new_server->prev = new_server;
246
244
*current_server = new_server;
245
/* Place the new server last in the list */
248
/* Place the new server last in the list */
249
247
new_server->next = *current_server;
250
248
new_server->prev = (*current_server)->prev;
251
249
new_server->prev->next = new_server;
258
256
* Initialize GPGME.
260
__attribute__((nonnull, warn_unused_result))
261
static bool init_gpgme(const char * const seckey,
262
const char * const pubkey,
263
const char * const tempdir,
258
static bool init_gpgme(const char *seckey, const char *pubkey,
259
const char *tempdir, mandos_context *mc){
265
260
gpgme_error_t rc;
266
261
gpgme_engine_info_t engine_info;
269
264
* Helper function to insert pub and seckey to the engine keyring.
271
bool import_key(const char * const filename){
266
bool import_key(const char *filename){
274
269
gpgme_data_t pgp_data;
492
485
/* GnuTLS log function callback */
493
__attribute__((nonnull))
494
486
static void debuggnutls(__attribute__((unused)) int level,
495
487
const char* string){
496
488
fprintf_plus(stderr, "GnuTLS: %s", string);
499
__attribute__((nonnull, warn_unused_result))
500
491
static int init_gnutls_global(const char *pubkeyfilename,
501
492
const char *seckeyfilename,
502
493
mandos_context *mc){
639
629
__attribute__((unused)) const char *txt){}
641
631
/* Called when a Mandos server is found */
642
__attribute__((nonnull, warn_unused_result))
643
632
static int start_mandos_communication(const char *ip, in_port_t port,
644
633
AvahiIfIndex if_index,
645
634
int af, mandos_context *mc){
1253
1239
* corresponds to an acceptable network device.
1254
1240
* (This function is passed to scandir(3) as a filter function.)
1256
__attribute__((nonnull, warn_unused_result))
1257
1242
int good_interface(const struct dirent *if_entry){
1258
1243
if(if_entry->d_name[0] == '.'){
1278
1263
* This function determines if a network interface is up.
1280
__attribute__((nonnull, warn_unused_result))
1281
1265
bool interface_is_up(const char *interface){
1282
1266
struct ifreq ifr;
1283
1267
if(not get_flags(interface, &ifr)){
1295
1279
* This function determines if a network interface is running
1297
__attribute__((nonnull, warn_unused_result))
1298
1281
bool interface_is_running(const char *interface){
1299
1282
struct ifreq ifr;
1300
1283
if(not get_flags(interface, &ifr)){
1308
1291
return (bool)(ifr.ifr_flags & IFF_RUNNING);
1311
__attribute__((nonnull, pure, warn_unused_result))
1312
1294
int notdotentries(const struct dirent *direntry){
1313
1295
/* Skip "." and ".." */
1314
1296
if(direntry->d_name[0] == '.'
1459
1439
/* Set effective uid to 0, return errno */
1460
__attribute__((warn_unused_result))
1461
1440
error_t raise_privileges(void){
1462
1441
error_t old_errno = errno;
1463
1442
error_t ret_errno = 0;
1472
1451
/* Set effective and real user ID to 0. Return errno. */
1473
__attribute__((warn_unused_result))
1474
1452
error_t raise_privileges_permanently(void){
1475
1453
error_t old_errno = errno;
1476
1454
error_t ret_errno = raise_privileges();
1512
1488
return ret_errno;
1515
__attribute__((nonnull))
1516
void run_network_hooks(const char *mode, const char *interface,
1491
bool run_network_hooks(const char *mode, const char *interface,
1517
1492
const float delay){
1518
1493
struct dirent **direntries;
1519
1494
int numhooks = scandir(hookdir, &direntries, runnable_hook,
1547
1522
if(hook_pid == 0){
1549
1524
/* Raise privileges */
1550
if(raise_privileges_permanently() != 0){
1551
perror_plus("Failed to raise privileges");
1525
raise_privileges_permanently();
1554
1526
/* Set group */
1556
1528
ret = setgid(0);
1558
1530
perror_plus("setgid");
1561
1532
/* Reset supplementary groups */
1563
1534
ret = setgroups(0, NULL);
1565
1536
perror_plus("setgroups");
1568
ret = dup2(devnull, STDIN_FILENO);
1570
perror_plus("dup2(devnull, STDIN_FILENO)");
1573
ret = close(devnull);
1575
perror_plus("close");
1578
ret = dup2(STDERR_FILENO, STDOUT_FILENO);
1580
perror_plus("dup2(STDERR_FILENO, STDOUT_FILENO)");
1538
dup2(devnull, STDIN_FILENO);
1540
dup2(STDERR_FILENO, STDOUT_FILENO);
1583
1541
ret = setenv("MANDOSNETHOOKDIR", hookdir, 1);
1585
1543
perror_plus("setenv");
1661
1619
close(devnull);
1665
__attribute__((nonnull, warn_unused_result))
1666
1624
error_t bring_up_interface(const char *const interface,
1667
1625
const float delay){
1668
1627
error_t old_errno = errno;
1628
error_t ret_errno = 0;
1629
int ret, ret_setflags;
1670
1630
struct ifreq network;
1671
1631
unsigned int if_index = if_nametoindex(interface);
1672
1632
if(if_index == 0){
1683
1643
if(not interface_is_up(interface)){
1684
error_t ret_errno = 0, ioctl_errno = 0;
1685
if(not get_flags(interface, &network)){
1644
if(not get_flags(interface, &network) and debug){
1686
1645
ret_errno = errno;
1687
1646
fprintf_plus(stderr, "Failed to get flags for interface "
1688
1647
"\"%s\"\n", interface);
1690
1648
return ret_errno;
1692
network.ifr_flags |= IFF_UP; /* set flag */
1650
network.ifr_flags |= IFF_UP;
1694
int sd = socket(PF_INET6, SOCK_DGRAM, IPPROTO_IP);
1652
sd = socket(PF_INET6, SOCK_DGRAM, IPPROTO_IP);
1696
1654
ret_errno = errno;
1697
1655
perror_plus("socket");
1698
1656
errno = old_errno;
1699
1657
return ret_errno;
1703
ret = (int)TEMP_FAILURE_RETRY(close(sd));
1705
perror_plus("close");
1707
1662
errno = old_errno;
1716
/* Raise privileges */
1717
ret_errno = raise_privileges();
1718
bool restore_loglevel = false;
1720
perror_plus("Failed to raise privileges");
1671
/* Raise priviliges */
1722
1674
#ifdef __linux__
1725
/* Lower kernel loglevel to KERN_NOTICE to avoid KERN_INFO
1726
messages about the network interface to mess up the prompt */
1727
ret_linux = klogctl(8, NULL, 5);
1728
if(ret_linux == -1){
1729
perror_plus("klogctl");
1731
restore_loglevel = true;
1675
/* Lower kernel loglevel to KERN_NOTICE to avoid KERN_INFO
1676
messages about the network interface to mess up the prompt */
1677
int ret_linux = klogctl(8, NULL, 5);
1678
bool restore_loglevel = true;
1679
if(ret_linux == -1){
1680
restore_loglevel = false;
1681
perror_plus("klogctl");
1734
1683
#endif /* __linux__ */
1735
int ret_setflags = ioctl(sd, SIOCSIFFLAGS, &network);
1736
ioctl_errno = errno;
1684
ret_setflags = ioctl(sd, SIOCSIFFLAGS, &network);
1737
1686
#ifdef __linux__
1738
1687
if(restore_loglevel){
1739
1688
ret_linux = klogctl(7, NULL, 0);
1800
1741
if(interface_is_up(interface)){
1801
error_t ret_errno = 0, ioctl_errno = 0;
1742
error_t ret_errno = 0;
1802
1743
if(not get_flags(interface, &network) and debug){
1803
1744
ret_errno = errno;
1804
1745
fprintf_plus(stderr, "Failed to get flags for interface "
1805
1746
"\"%s\"\n", interface);
1807
1747
return ret_errno;
1809
1749
network.ifr_flags &= ~(short)IFF_UP; /* clear flag */
1811
1751
int sd = socket(PF_INET6, SOCK_DGRAM, IPPROTO_IP);
1813
1753
ret_errno = errno;
1814
1754
perror_plus("socket");
1815
1755
errno = old_errno;
1824
/* Raise privileges */
1825
ret_errno = raise_privileges();
1827
perror_plus("Failed to raise privileges");
1764
/* Raise priviliges */
1829
1767
int ret_setflags = ioctl(sd, SIOCSIFFLAGS, &network);
1830
ioctl_errno = errno;
1832
/* If raise_privileges() succeeded above */
1834
/* Lower privileges */
1835
ret_errno = lower_privileges();
1838
perror_plus("Failed to lower privileges");
1770
/* Lower privileges */
1842
1773
/* Close the socket */
1843
1774
int ret = (int)TEMP_FAILURE_RETRY(close(sd));
1863
1794
int main(int argc, char *argv[]){
1864
1795
mandos_context mc = { .server = NULL, .dh_bits = 1024,
1865
1796
.priority = "SECURE256:!CTYPE-X.509:"
1866
"+CTYPE-OPENPGP", .current_server = NULL,
1797
"+CTYPE-OPENPGP", .current_server = NULL,
1867
1798
.interfaces = NULL, .interfaces_size = 0 };
1868
1799
AvahiSServiceBrowser *sb = NULL;
1869
1800
error_t ret_errno;
1873
1804
int exitcode = EXIT_SUCCESS;
1874
1805
char *interfaces_to_take_down = NULL;
1875
1806
size_t interfaces_to_take_down_size = 0;
1876
char run_tempdir[] = "/run/tmp/mandosXXXXXX";
1877
char old_tempdir[] = "/tmp/mandosXXXXXX";
1878
char *tempdir = NULL;
1807
char tempdir[] = "/tmp/mandosXXXXXX";
1808
bool tempdir_created = false;
1879
1809
AvahiIfIndex if_index = AVAHI_IF_UNSPEC;
1880
1810
const char *seckey = PATHDIR "/" SECKEY;
1881
1811
const char *pubkey = PATHDIR "/" PUBKEY;
2063
1993
/* Work around Debian bug #633582:
2064
1994
<http://bugs.debian.org/633582> */
2066
/* Re-raise privileges */
2067
ret_errno = raise_privileges();
2070
perror_plus("Failed to raise privileges");
1996
/* Re-raise priviliges */
1997
if(raise_privileges() == 0){
2072
1998
struct stat st;
2074
2000
if(strcmp(seckey, PATHDIR "/" SECKEY) == 0){
2150
2072
memcpy(interfaces_hooks, mc.interfaces, mc.interfaces_size);
2151
2073
argz_stringify(interfaces_hooks, mc.interfaces_size, (int)',');
2153
run_network_hooks("start", interfaces_hooks != NULL ?
2154
interfaces_hooks : "", delay);
2075
if(not run_network_hooks("start", interfaces_hooks != NULL ?
2076
interfaces_hooks : "", delay)){
2287
2211
bool interface_was_up = interface_is_up(interface);
2288
errno = bring_up_interface(interface, delay);
2212
ret = bring_up_interface(interface, delay);
2289
2213
if(not interface_was_up){
2291
2216
perror_plus("Failed to bring up interface");
2293
errno = argz_add(&interfaces_to_take_down,
2294
&interfaces_to_take_down_size,
2218
ret_errno = argz_add(&interfaces_to_take_down,
2219
&interfaces_to_take_down_size,
2297
2223
perror_plus("argz_add");
2333
/* Try /run/tmp before /tmp */
2334
tempdir = mkdtemp(run_tempdir);
2335
if(tempdir == NULL and errno == ENOENT){
2337
fprintf_plus(stderr, "Tempdir %s did not work, trying %s\n",
2338
run_tempdir, old_tempdir);
2340
tempdir = mkdtemp(old_tempdir);
2342
if(tempdir == NULL){
2259
if(mkdtemp(tempdir) == NULL){
2343
2260
perror_plus("mkdtemp");
2263
tempdir_created = true;
2534
/* Re-raise privileges */
2452
/* Re-raise priviliges */
2536
ret_errno = raise_privileges();
2538
perror_plus("Failed to raise privileges");
2541
/* Run network hooks */
2542
run_network_hooks("stop", interfaces_hooks != NULL ?
2543
interfaces_hooks : "", delay);
2545
/* Take down the network interfaces which were brought up */
2547
char *interface = NULL;
2548
while((interface=argz_next(interfaces_to_take_down,
2549
interfaces_to_take_down_size,
2551
ret_errno = take_down_interface(interface);
2554
perror_plus("Failed to take down interface");
2557
if(debug and (interfaces_to_take_down == NULL)){
2558
fprintf_plus(stderr, "No interfaces needed to be taken"
2563
ret_errno = lower_privileges_permanently();
2565
perror_plus("Failed to lower privileges permanently");
2456
/* Run network hooks */
2457
run_network_hooks("stop", interfaces_hooks != NULL ?
2458
interfaces_hooks : "", delay);
2460
/* Take down the network interfaces which were brought up */
2462
char *interface = NULL;
2463
while((interface=argz_next(interfaces_to_take_down,
2464
interfaces_to_take_down_size,
2466
ret_errno = take_down_interface(interface);
2469
perror_plus("Failed to take down interface");
2472
if(debug and (interfaces_to_take_down == NULL)){
2473
fprintf_plus(stderr, "No interfaces needed to be taken"
2478
lower_privileges_permanently();
2569
2481
free(interfaces_to_take_down);
2570
2482
free(interfaces_hooks);
2572
2484
/* Removes the GPGME temp directory and all files inside */
2573
if(tempdir != NULL){
2485
if(tempdir_created){
2574
2486
struct dirent **direntries = NULL;
2575
2487
struct dirent *direntry = NULL;
2576
2488
int numentries = scandir(tempdir, &direntries, notdotentries,