226
235
if(new_server->ip == NULL){
227
236
perror_plus("strdup");
240
ret = clock_gettime(CLOCK_MONOTONIC, &(new_server->last_seen));
242
perror_plus("clock_gettime");
244
#pragma GCC diagnostic push
245
#pragma GCC diagnostic ignored "-Wcast-qual"
247
free((char *)(new_server->ip));
249
#pragma GCC diagnostic pop
230
254
/* Special case of first server */
231
if (mc.current_server == NULL){
255
if(*current_server == NULL){
232
256
new_server->next = new_server;
233
257
new_server->prev = new_server;
234
mc.current_server = new_server;
235
/* Place the new server last in the list */
258
*current_server = new_server;
237
new_server->next = mc.current_server;
238
new_server->prev = mc.current_server->prev;
260
/* Place the new server last in the list */
261
new_server->next = *current_server;
262
new_server->prev = (*current_server)->prev;
239
263
new_server->prev->next = new_server;
240
mc.current_server->prev = new_server;
242
ret = clock_gettime(CLOCK_MONOTONIC, &mc.current_server->last_seen);
244
perror_plus("clock_gettime");
264
(*current_server)->prev = new_server;
538
564
/* GnuTLS server initialization */
539
ret = gnutls_dh_params_init(&mc.dh_params);
565
ret = gnutls_dh_params_init(&mc->dh_params);
540
566
if(ret != GNUTLS_E_SUCCESS){
541
567
fprintf_plus(stderr, "Error in GnuTLS DH parameter"
542
568
" initialization: %s\n",
543
569
safer_gnutls_strerror(ret));
546
ret = gnutls_dh_params_generate2(mc.dh_params, mc.dh_bits);
572
ret = gnutls_dh_params_generate2(mc->dh_params, mc->dh_bits);
547
573
if(ret != GNUTLS_E_SUCCESS){
548
574
fprintf_plus(stderr, "Error in GnuTLS prime generation: %s\n",
549
575
safer_gnutls_strerror(ret));
553
gnutls_certificate_set_dh_params(mc.cred, mc.dh_params);
579
gnutls_certificate_set_dh_params(mc->cred, mc->dh_params);
559
gnutls_certificate_free_credentials(mc.cred);
585
gnutls_certificate_free_credentials(mc->cred);
560
586
gnutls_global_deinit();
561
gnutls_dh_params_deinit(mc.dh_params);
587
gnutls_dh_params_deinit(mc->dh_params);
565
static int init_gnutls_session(gnutls_session_t *session){
591
__attribute__((nonnull, warn_unused_result))
592
static int init_gnutls_session(gnutls_session_t *session,
567
595
/* GnuTLS session creation */
738
790
if(if_indextoname((unsigned int)if_index, interface) == NULL){
739
791
perror_plus("if_indextoname");
741
fprintf_plus(stderr, "Connection to: %s%%%s, port %" PRIu16
742
"\n", ip, interface, port);
793
fprintf_plus(stderr, "Connection to: %s%%%s, port %" PRIuMAX
794
"\n", ip, interface, (uintmax_t)port);
745
fprintf_plus(stderr, "Connection to: %s, port %" PRIu16 "\n",
797
fprintf_plus(stderr, "Connection to: %s, port %" PRIuMAX "\n",
798
ip, (uintmax_t)port);
748
800
char addrstr[(INET_ADDRSTRLEN > INET6_ADDRSTRLEN) ?
749
801
INET_ADDRSTRLEN : INET6_ADDRSTRLEN] = "";
751
802
if(af == AF_INET6){
752
pcret = inet_ntop(af, &(to.in6.sin6_addr), addrstr,
803
ret = getnameinfo((struct sockaddr *)&to,
804
sizeof(struct sockaddr_in6),
805
addrstr, sizeof(addrstr), NULL, 0,
755
pcret = inet_ntop(af, &(to.in.sin_addr), addrstr,
808
ret = getnameinfo((struct sockaddr *)&to,
809
sizeof(struct sockaddr_in),
810
addrstr, sizeof(addrstr), NULL, 0,
759
perror_plus("inet_ntop");
761
if(strcmp(addrstr, ip) != 0){
762
fprintf_plus(stderr, "Canonical address form: %s\n", addrstr);
813
if(ret == EAI_SYSTEM){
814
perror_plus("getnameinfo");
815
} else if(ret != 0) {
816
fprintf_plus(stderr, "getnameinfo: %s", gai_strerror(ret));
817
} else if(strcmp(addrstr, ip) != 0){
818
fprintf_plus(stderr, "Canonical address form: %s\n", addrstr);
1413
1485
if(setuid(0) == -1){
1414
1486
ret_errno = errno;
1415
perror_plus("seteuid");
1417
1488
errno = old_errno;
1418
1489
return ret_errno;
1421
1492
/* Set effective user ID to unprivileged saved user ID */
1493
__attribute__((warn_unused_result))
1422
1494
error_t lower_privileges(void){
1423
1495
error_t old_errno = errno;
1424
1496
error_t ret_errno = 0;
1425
1497
if(seteuid(uid) == -1){
1426
1498
ret_errno = errno;
1427
perror_plus("seteuid");
1429
1500
errno = old_errno;
1430
1501
return ret_errno;
1433
1504
/* Lower privileges permanently */
1505
__attribute__((warn_unused_result))
1434
1506
error_t lower_privileges_permanently(void){
1435
1507
error_t old_errno = errno;
1436
1508
error_t ret_errno = 0;
1437
1509
if(setuid(uid) == -1){
1438
1510
ret_errno = errno;
1439
perror_plus("setuid");
1441
1512
errno = old_errno;
1442
1513
return ret_errno;
1445
bool run_network_hooks(const char *mode, const char *interface,
1516
__attribute__((nonnull))
1517
void run_network_hooks(const char *mode, const char *interface,
1446
1518
const float delay){
1447
struct dirent **direntries;
1448
struct dirent *direntry;
1450
int numhooks = scandir(hookdir, &direntries, runnable_hook,
1519
struct dirent **direntries = NULL;
1520
if(hookdir_fd == -1){
1521
hookdir_fd = open(hookdir, O_RDONLY);
1522
if(hookdir_fd == -1){
1523
if(errno == ENOENT){
1525
fprintf_plus(stderr, "Network hook directory \"%s\" not"
1526
" found\n", hookdir);
1529
perror_plus("open");
1535
#if __GLIBC_PREREQ(2, 15)
1536
int numhooks = scandirat(hookdir_fd, ".", &direntries,
1537
runnable_hook, alphasort);
1538
#else /* not __GLIBC_PREREQ(2, 15) */
1539
int numhooks = scandir(hookdir, &direntries, runnable_hook,
1541
#endif /* not __GLIBC_PREREQ(2, 15) */
1542
#else /* not __GLIBC__ */
1543
int numhooks = scandir(hookdir, &direntries, runnable_hook,
1545
#endif /* not __GLIBC__ */
1452
1546
if(numhooks == -1){
1453
1547
perror_plus("scandir");
1455
int devnull = open("/dev/null", O_RDONLY);
1456
for(int i = 0; i < numhooks; i++){
1457
direntry = direntries[i];
1458
char *fullname = NULL;
1459
ret = asprintf(&fullname, "%s/%s", hookdir, direntry->d_name);
1550
struct dirent *direntry;
1552
int devnull = open("/dev/null", O_RDONLY);
1553
for(int i = 0; i < numhooks; i++){
1554
direntry = direntries[i];
1556
fprintf_plus(stderr, "Running network hook \"%s\"\n",
1559
pid_t hook_pid = fork();
1562
/* Raise privileges */
1563
errno = raise_privileges_permanently();
1565
perror_plus("Failed to raise privileges");
1572
perror_plus("setgid");
1575
/* Reset supplementary groups */
1577
ret = setgroups(0, NULL);
1579
perror_plus("setgroups");
1582
ret = dup2(devnull, STDIN_FILENO);
1584
perror_plus("dup2(devnull, STDIN_FILENO)");
1587
ret = close(devnull);
1589
perror_plus("close");
1592
ret = dup2(STDERR_FILENO, STDOUT_FILENO);
1594
perror_plus("dup2(STDERR_FILENO, STDOUT_FILENO)");
1597
ret = setenv("MANDOSNETHOOKDIR", hookdir, 1);
1599
perror_plus("setenv");
1602
ret = setenv("DEVICE", interface, 1);
1604
perror_plus("setenv");
1607
ret = setenv("VERBOSITY", debug ? "1" : "0", 1);
1609
perror_plus("setenv");
1612
ret = setenv("MODE", mode, 1);
1614
perror_plus("setenv");
1618
ret = asprintf(&delaystring, "%f", (double)delay);
1461
1620
perror_plus("asprintf");
1465
fprintf_plus(stderr, "Running network hook \"%s\"\n",
1468
pid_t hook_pid = fork();
1471
/* Raise privileges */
1472
raise_privileges_permanently();
1477
perror_plus("setgid");
1479
/* Reset supplementary groups */
1481
ret = setgroups(0, NULL);
1483
perror_plus("setgroups");
1485
dup2(devnull, STDIN_FILENO);
1487
dup2(STDERR_FILENO, STDOUT_FILENO);
1488
ret = setenv("MANDOSNETHOOKDIR", hookdir, 1);
1490
perror_plus("setenv");
1493
ret = setenv("DEVICE", interface, 1);
1495
perror_plus("setenv");
1498
ret = setenv("VERBOSITY", debug ? "1" : "0", 1);
1500
perror_plus("setenv");
1503
ret = setenv("MODE", mode, 1);
1505
perror_plus("setenv");
1509
ret = asprintf(&delaystring, "%f", delay);
1511
perror_plus("asprintf");
1514
ret = setenv("DELAY", delaystring, 1);
1517
perror_plus("setenv");
1623
ret = setenv("DELAY", delaystring, 1);
1520
1625
free(delaystring);
1521
if(connect_to != NULL){
1522
ret = setenv("CONNECT", connect_to, 1);
1524
perror_plus("setenv");
1528
if(execl(fullname, direntry->d_name, mode, NULL) == -1){
1529
perror_plus("execl");
1530
_exit(EXIT_FAILURE);
1626
perror_plus("setenv");
1630
if(connect_to != NULL){
1631
ret = setenv("CONNECT", connect_to, 1);
1633
perror_plus("setenv");
1637
int hook_fd = openat(hookdir_fd, direntry->d_name, O_RDONLY);
1639
perror_plus("openat");
1640
_exit(EXIT_FAILURE);
1642
if((int)TEMP_FAILURE_RETRY(close(hookdir_fd)) == -1){
1643
perror_plus("close");
1644
_exit(EXIT_FAILURE);
1646
if(fexecve(hook_fd, (char *const []){ direntry->d_name, NULL },
1648
perror_plus("fexecve");
1649
_exit(EXIT_FAILURE);
1653
if(TEMP_FAILURE_RETRY(waitpid(hook_pid, &status, 0)) == -1){
1654
perror_plus("waitpid");
1657
if(WIFEXITED(status)){
1658
if(WEXITSTATUS(status) != 0){
1659
fprintf_plus(stderr, "Warning: network hook \"%s\" exited"
1660
" with status %d\n", direntry->d_name,
1661
WEXITSTATUS(status));
1664
} else if(WIFSIGNALED(status)){
1665
fprintf_plus(stderr, "Warning: network hook \"%s\" died by"
1666
" signal %d\n", direntry->d_name,
1534
if(TEMP_FAILURE_RETRY(waitpid(hook_pid, &status, 0)) == -1){
1535
perror_plus("waitpid");
1539
if(WIFEXITED(status)){
1540
if(WEXITSTATUS(status) != 0){
1541
fprintf_plus(stderr, "Warning: network hook \"%s\" exited"
1542
" with status %d\n", direntry->d_name,
1543
WEXITSTATUS(status));
1547
} else if(WIFSIGNALED(status)){
1548
fprintf_plus(stderr, "Warning: network hook \"%s\" died by"
1549
" signal %d\n", direntry->d_name,
1554
fprintf_plus(stderr, "Warning: network hook \"%s\""
1555
" crashed\n", direntry->d_name);
1562
fprintf_plus(stderr, "Network hook \"%s\" ran successfully\n",
1670
fprintf_plus(stderr, "Warning: network hook \"%s\""
1671
" crashed\n", direntry->d_name);
1676
fprintf_plus(stderr, "Network hook \"%s\" ran successfully\n",
1681
if((int)TEMP_FAILURE_RETRY(close(hookdir_fd)) == -1){
1682
perror_plus("close");
1689
__attribute__((nonnull, warn_unused_result))
1571
1690
error_t bring_up_interface(const char *const interface,
1572
1691
const float delay){
1574
1692
error_t old_errno = errno;
1575
error_t ret_errno = 0;
1576
int ret, ret_setflags;
1577
1694
struct ifreq network;
1578
1695
unsigned int if_index = if_nametoindex(interface);
1579
1696
if(if_index == 0){
2129
2285
free(direntries);
2132
2290
fprintf_plus(stderr, "Could not find a network interface\n");
2133
2291
exitcode = EXIT_FAILURE;
2138
/* If we only got one interface, explicitly use only that one */
2139
if(argz_count(interfaces, interfaces_size) == 1){
2141
fprintf_plus(stderr, "Using only interface \"%s\"\n",
2144
if_index = (AvahiIfIndex)if_nametoindex(interfaces);
2147
/* Bring up interfaces which are down */
2148
if(not (argz_count(interfaces, interfaces_size) == 1
2149
and strcmp(interfaces, "none") == 0)){
2296
/* Bring up interfaces which are down, and remove any "none"s */
2150
2298
char *interface = NULL;
2151
while((interface = argz_next(interfaces, interfaces_size,
2299
while((interface = argz_next(mc.interfaces, mc.interfaces_size,
2301
/* If interface name is "none", stop bringing up interfaces.
2302
Also remove all instances of "none" from the list */
2303
if(strcmp(interface, "none") == 0){
2304
argz_delete(&mc.interfaces, &mc.interfaces_size,
2307
while((interface = argz_next(mc.interfaces,
2308
mc.interfaces_size, interface))){
2309
if(strcmp(interface, "none") == 0){
2310
argz_delete(&mc.interfaces, &mc.interfaces_size,
2153
2317
bool interface_was_up = interface_is_up(interface);
2154
ret = bring_up_interface(interface, delay);
2318
errno = bring_up_interface(interface, delay);
2155
2319
if(not interface_was_up){
2158
2321
perror_plus("Failed to bring up interface");
2160
ret_errno = argz_add(&interfaces_to_take_down,
2161
&interfaces_to_take_down_size,
2323
errno = argz_add(&interfaces_to_take_down,
2324
&interfaces_to_take_down_size,
2327
perror_plus("argz_add");
2168
interfaces_size = 0;
2169
2332
if(debug and (interfaces_to_take_down == NULL)){
2170
2333
fprintf_plus(stderr, "No interfaces were brought up\n");
2337
/* If we only got one interface, explicitly use only that one */
2338
if(argz_count(mc.interfaces, mc.interfaces_size) == 1){
2340
fprintf_plus(stderr, "Using only interface \"%s\"\n",
2343
if_index = (AvahiIfIndex)if_nametoindex(mc.interfaces);
2178
ret = init_gnutls_global(pubkey, seckey);
2350
ret = init_gnutls_global(pubkey, seckey, &mc);
2180
2352
fprintf_plus(stderr, "init_gnutls_global failed\n");
2181
2353
exitcode = EX_UNAVAILABLE;
2373
2556
mc.current_server->prev->next = NULL;
2374
2557
while(mc.current_server != NULL){
2375
2558
server *next = mc.current_server->next;
2560
#pragma GCC diagnostic push
2561
#pragma GCC diagnostic ignored "-Wcast-qual"
2563
free((char *)(mc.current_server->ip));
2565
#pragma GCC diagnostic pop
2376
2567
free(mc.current_server);
2377
2568
mc.current_server = next;
2381
/* Re-raise priviliges */
2572
/* Re-raise privileges */
2385
/* Run network hooks */
2386
run_network_hooks("stop", interfaces_hooks, delay);
2388
/* Take down the network interfaces which were brought up */
2390
char *interface = NULL;
2391
while((interface=argz_next(interfaces_to_take_down,
2392
interfaces_to_take_down_size,
2394
ret_errno = take_down_interface(interface);
2397
perror_plus("Failed to take down interface");
2400
if(debug and (interfaces_to_take_down == NULL)){
2401
fprintf_plus(stderr, "No interfaces needed to be taken"
2406
lower_privileges_permanently();
2574
ret_errno = raise_privileges();
2577
perror_plus("Failed to raise privileges");
2580
/* Run network hooks */
2581
run_network_hooks("stop", interfaces_hooks != NULL ?
2582
interfaces_hooks : "", delay);
2584
/* Take down the network interfaces which were brought up */
2586
char *interface = NULL;
2587
while((interface=argz_next(interfaces_to_take_down,
2588
interfaces_to_take_down_size,
2590
ret_errno = take_down_interface(interface);
2593
perror_plus("Failed to take down interface");
2596
if(debug and (interfaces_to_take_down == NULL)){
2597
fprintf_plus(stderr, "No interfaces needed to be taken"
2603
ret_errno = lower_privileges_permanently();
2606
perror_plus("Failed to lower privileges permanently");
2409
2610
free(interfaces_to_take_down);
2410
2611
free(interfaces_hooks);
2412
2613
/* Removes the GPGME temp directory and all files inside */
2413
if(tempdir_created){
2614
if(tempdir != NULL){
2414
2615
struct dirent **direntries = NULL;
2415
struct dirent *direntry = NULL;
2416
int numentries = scandir(tempdir, &direntries, notdotentries,
2418
if (numentries > 0){
2419
for(int i = 0; i < numentries; i++){
2420
direntry = direntries[i];
2421
char *fullname = NULL;
2422
ret = asprintf(&fullname, "%s/%s", tempdir,
2425
perror_plus("asprintf");
2428
ret = remove(fullname);
2430
fprintf_plus(stderr, "remove(\"%s\"): %s\n", fullname,
2616
int tempdir_fd = (int)TEMP_FAILURE_RETRY(open(tempdir, O_RDONLY |
2618
if(tempdir_fd == -1){
2619
perror_plus("open");
2622
#if __GLIBC_PREREQ(2, 15)
2623
int numentries = scandirat(tempdir_fd, ".", &direntries,
2624
notdotentries, alphasort);
2625
#else /* not __GLIBC_PREREQ(2, 15) */
2626
int numentries = scandir(tempdir, &direntries, notdotentries,
2628
#endif /* not __GLIBC_PREREQ(2, 15) */
2629
#else /* not __GLIBC__ */
2630
int numentries = scandir(tempdir, &direntries, notdotentries,
2632
#endif /* not __GLIBC__ */
2633
if(numentries >= 0){
2634
for(int i = 0; i < numentries; i++){
2635
ret = unlinkat(tempdir_fd, direntries[i]->d_name, 0);
2637
fprintf_plus(stderr, "unlinkat(open(\"%s\", O_RDONLY),"
2638
" \"%s\", 0): %s\n", tempdir,
2639
direntries[i]->d_name, strerror(errno));
2643
/* need to clean even if 0 because man page doesn't specify */
2645
if(numentries == -1){
2646
perror_plus("scandir");
2648
ret = rmdir(tempdir);
2649
if(ret == -1 and errno != ENOENT){
2650
perror_plus("rmdir");
2437
/* need to clean even if 0 because man page doesn't specify */
2439
if (numentries == -1){
2440
perror_plus("scandir");
2442
ret = rmdir(tempdir);
2443
if(ret == -1 and errno != ENOENT){
2444
perror_plus("rmdir");
2653
TEMP_FAILURE_RETRY(close(tempdir_fd));