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 683
- compare with another revision
- download diff
- download tarball
- view history from revision 683
- Committer: Teddy Hogeborn
- Date: 2014-05-12 21:02:38 UTC
- Revision ID: teddy@recompile.se-20140512210238-t6o8b1ieeojrs0xl
Do not run self-tests when building arch-indep Debian package.
* debian/rules (override_dh_auto_test-arch): New; does nothing.
* debian/rules (override_dh_auto_test-arch): New; does nothing.
- files modified:
- DBUS-API
added
removed
plugins.d/mandos-client.c
32
32
/* Needed by GPGME, specifically gpgme_data_seek() */
33
33
#ifndef _LARGEFILE_SOURCE
34
34
#define _LARGEFILE_SOURCE
35
#endif /* not _LARGEFILE_SOURCE */
35
#endif
36
36
#ifndef _FILE_OFFSET_BITS
37
37
#define _FILE_OFFSET_BITS 64
38
#endif /* not _FILE_OFFSET_BITS */
38
#endif
39
39
40
40
#define _GNU_SOURCE /* TEMP_FAILURE_RETRY(), asprintf() */
41
41
42
42
#include <stdio.h> /* fprintf(), stderr, fwrite(),
43
stdout, ferror() */
43
stdout, ferror(), remove() */
44
44
#include <stdint.h> /* uint16_t, uint32_t, intptr_t */
45
45
#include <stddef.h> /* NULL, size_t, ssize_t */
46
46
#include <stdlib.h> /* free(), EXIT_SUCCESS, srand(),
57
57
#include <sys/socket.h> /* socket(), struct sockaddr_in6,
58
58
inet_pton(), connect(),
59
59
getnameinfo() */
60
#include <fcntl.h> /* open(), unlinkat() */
60
#include <fcntl.h> /* open() */
61
61
#include <dirent.h> /* opendir(), struct dirent, readdir()
62
62
*/
63
63
#include <inttypes.h> /* PRIu16, PRIdMAX, intmax_t,
73
73
*/
74
74
#include <unistd.h> /* close(), SEEK_SET, off_t, write(),
75
75
getuid(), getgid(), seteuid(),
76
setgid(), pause(), _exit(),
77
unlinkat() */
76
setgid(), pause(), _exit() */
78
77
#include <arpa/inet.h> /* inet_pton(), htons() */
79
78
#include <iso646.h> /* not, or, and */
80
79
#include <argp.h> /* struct argp_option, error_t, struct
142
141
static const char sys_class_net[] = "/sys/class/net";
143
142
char *connect_to = NULL;
144
143
const char *hookdir = HOOKDIR;
145
int hookdir_fd = -1;
146
144
uid_t uid = 65534;
147
145
gid_t gid = 65534;
148
146
234
232
.af = af };
235
233
if(new_server->ip == NULL){
236
234
perror_plus("strdup");
237
free(new_server);
238
235
return false;
239
236
}
240
237
ret = clock_gettime(CLOCK_MONOTONIC, &(new_server->last_seen));
241
238
if(ret == -1){
242
239
perror_plus("clock_gettime");
243
#ifdef __GNUC__
244
#pragma GCC diagnostic push
245
#pragma GCC diagnostic ignored "-Wcast-qual"
246
#endif
247
free((char *)(new_server->ip));
248
#ifdef __GNUC__
249
#pragma GCC diagnostic pop
250
#endif
251
free(new_server);
252
240
return false;
253
241
}
254
242
/* Special case of first server */
1076
1064
timed out */
1077
1065
1078
1066
if(quit_now){
1079
avahi_s_service_resolver_free(r);
1080
1067
return;
1081
1068
}
1082
1069
1348
1335
sret = strspn(direntry->d_name, "ABCDEFGHIJKLMNOPQRSTUVWXYZ"
1349
1336
"abcdefghijklmnopqrstuvwxyz"
1350
1337
"0123456789"
1351
"_.-");
1338
"_-");
1352
1339
if((direntry->d_name)[sret] != '\0'){
1353
1340
/* Contains non-allowed characters */
1354
1341
if(debug){
1358
1345
return 0;
1359
1346
}
1360
1347
1361
ret = fstatat(hookdir_fd, direntry->d_name, &st, 0);
1348
char *fullname = NULL;
1349
ret = asprintf(&fullname, "%s/%s", hookdir, direntry->d_name);
1350
if(ret < 0){
1351
perror_plus("asprintf");
1352
return 0;
1353
}
1354
1355
ret = stat(fullname, &st);
1362
1356
if(ret == -1){
1363
1357
if(debug){
1364
1358
perror_plus("Could not stat hook");
1469
1463
error_t ret_errno = 0;
1470
1464
if(seteuid(0) == -1){
1471
1465
ret_errno = errno;
1466
perror_plus("seteuid");
1472
1467
}
1473
1468
errno = old_errno;
1474
1469
return ret_errno;
1485
1480
}
1486
1481
if(setuid(0) == -1){
1487
1482
ret_errno = errno;
1483
perror_plus("seteuid");
1488
1484
}
1489
1485
errno = old_errno;
1490
1486
return ret_errno;
1497
1493
error_t ret_errno = 0;
1498
1494
if(seteuid(uid) == -1){
1499
1495
ret_errno = errno;
1496
perror_plus("seteuid");
1500
1497
}
1501
1498
errno = old_errno;
1502
1499
return ret_errno;
1509
1506
error_t ret_errno = 0;
1510
1507
if(setuid(uid) == -1){
1511
1508
ret_errno = errno;
1509
perror_plus("setuid");
1512
1510
}
1513
1511
errno = old_errno;
1514
1512
return ret_errno;
1517
1515
__attribute__((nonnull))
1518
1516
void run_network_hooks(const char *mode, const char *interface,
1519
1517
const float delay){
1520
struct dirent **direntries = NULL;
1521
if(hookdir_fd == -1){
1522
hookdir_fd = open(hookdir, O_RDONLY);
1523
if(hookdir_fd == -1){
1524
if(errno == ENOENT){
1525
if(debug){
1526
fprintf_plus(stderr, "Network hook directory \"%s\" not"
1527
" found\n", hookdir);
1528
}
1529
} else {
1530
perror_plus("open");
1531
}
1532
return;
1533
}
1534
}
1535
#ifdef __GLIBC__
1536
#if __GLIBC_PREREQ(2, 15)
1537
int numhooks = scandirat(hookdir_fd, ".", &direntries,
1538
runnable_hook, alphasort);
1539
#else /* not __GLIBC_PREREQ(2, 15) */
1540
int numhooks = scandir(hookdir, &direntries, runnable_hook,
1541
alphasort);
1542
#endif /* not __GLIBC_PREREQ(2, 15) */
1543
#else /* not __GLIBC__ */
1544
int numhooks = scandir(hookdir, &direntries, runnable_hook,
1545
alphasort);
1546
#endif /* not __GLIBC__ */
1518
struct dirent **direntries;
1519
int numhooks = scandir(hookdir, &direntries, runnable_hook,
1520
alphasort);
1547
1521
if(numhooks == -1){
1548
perror_plus("scandir");
1549
return;
1550
}
1551
struct dirent *direntry;
1552
int ret;
1553
int devnull = open("/dev/null", O_RDONLY);
1554
for(int i = 0; i < numhooks; i++){
1555
direntry = direntries[i];
1556
if(debug){
1557
fprintf_plus(stderr, "Running network hook \"%s\"\n",
1558
direntry->d_name);
1522
if(errno == ENOENT){
1523
if(debug){
1524
fprintf_plus(stderr, "Network hook directory \"%s\" not"
1525
" found\n", hookdir);
1526
}
1527
} else {
1528
perror_plus("scandir");
1559
1529
}
1560
pid_t hook_pid = fork();
1561
if(hook_pid == 0){
1562
/* Child */
1563
/* Raise privileges */
1564
errno = raise_privileges_permanently();
1565
if(errno != 0){
1566
perror_plus("Failed to raise privileges");
1567
_exit(EX_NOPERM);
1568
}
1569
/* Set group */
1570
errno = 0;
1571
ret = setgid(0);
1572
if(ret == -1){
1573
perror_plus("setgid");
1574
_exit(EX_NOPERM);
1575
}
1576
/* Reset supplementary groups */
1577
errno = 0;
1578
ret = setgroups(0, NULL);
1579
if(ret == -1){
1580
perror_plus("setgroups");
1581
_exit(EX_NOPERM);
1582
}
1583
ret = dup2(devnull, STDIN_FILENO);
1584
if(ret == -1){
1585
perror_plus("dup2(devnull, STDIN_FILENO)");
1586
_exit(EX_OSERR);
1587
}
1588
ret = close(devnull);
1589
if(ret == -1){
1590
perror_plus("close");
1591
_exit(EX_OSERR);
1592
}
1593
ret = dup2(STDERR_FILENO, STDOUT_FILENO);
1594
if(ret == -1){
1595
perror_plus("dup2(STDERR_FILENO, STDOUT_FILENO)");
1596
_exit(EX_OSERR);
1597
}
1598
ret = setenv("MANDOSNETHOOKDIR", hookdir, 1);
1599
if(ret == -1){
1600
perror_plus("setenv");
1601
_exit(EX_OSERR);
1602
}
1603
ret = setenv("DEVICE", interface, 1);
1604
if(ret == -1){
1605
perror_plus("setenv");
1606
_exit(EX_OSERR);
1607
}
1608
ret = setenv("VERBOSITY", debug ? "1" : "0", 1);
1609
if(ret == -1){
1610
perror_plus("setenv");
1611
_exit(EX_OSERR);
1612
}
1613
ret = setenv("MODE", mode, 1);
1614
if(ret == -1){
1615
perror_plus("setenv");
1616
_exit(EX_OSERR);
1617
}
1618
char *delaystring;
1619
ret = asprintf(&delaystring, "%f", (double)delay);
1620
if(ret == -1){
1530
} else {
1531
struct dirent *direntry;
1532
int ret;
1533
int devnull = open("/dev/null", O_RDONLY);
1534
for(int i = 0; i < numhooks; i++){
1535
direntry = direntries[i];
1536
char *fullname = NULL;
1537
ret = asprintf(&fullname, "%s/%s", hookdir, direntry->d_name);
1538
if(ret < 0){
1621
1539
perror_plus("asprintf");
1622
_exit(EX_OSERR);
1623
}
1624
ret = setenv("DELAY", delaystring, 1);
1625
if(ret == -1){
1540
continue;
1541
}
1542
if(debug){
1543
fprintf_plus(stderr, "Running network hook \"%s\"\n",
1544
direntry->d_name);
1545
}
1546
pid_t hook_pid = fork();
1547
if(hook_pid == 0){
1548
/* Child */
1549
/* Raise privileges */
1550
if(raise_privileges_permanently() != 0){
1551
perror_plus("Failed to raise privileges");
1552
_exit(EX_NOPERM);
1553
}
1554
/* Set group */
1555
errno = 0;
1556
ret = setgid(0);
1557
if(ret == -1){
1558
perror_plus("setgid");
1559
_exit(EX_NOPERM);
1560
}
1561
/* Reset supplementary groups */
1562
errno = 0;
1563
ret = setgroups(0, NULL);
1564
if(ret == -1){
1565
perror_plus("setgroups");
1566
_exit(EX_NOPERM);
1567
}
1568
ret = dup2(devnull, STDIN_FILENO);
1569
if(ret == -1){
1570
perror_plus("dup2(devnull, STDIN_FILENO)");
1571
_exit(EX_OSERR);
1572
}
1573
ret = close(devnull);
1574
if(ret == -1){
1575
perror_plus("close");
1576
_exit(EX_OSERR);
1577
}
1578
ret = dup2(STDERR_FILENO, STDOUT_FILENO);
1579
if(ret == -1){
1580
perror_plus("dup2(STDERR_FILENO, STDOUT_FILENO)");
1581
_exit(EX_OSERR);
1582
}
1583
ret = setenv("MANDOSNETHOOKDIR", hookdir, 1);
1584
if(ret == -1){
1585
perror_plus("setenv");
1586
_exit(EX_OSERR);
1587
}
1588
ret = setenv("DEVICE", interface, 1);
1589
if(ret == -1){
1590
perror_plus("setenv");
1591
_exit(EX_OSERR);
1592
}
1593
ret = setenv("VERBOSITY", debug ? "1" : "0", 1);
1594
if(ret == -1){
1595
perror_plus("setenv");
1596
_exit(EX_OSERR);
1597
}
1598
ret = setenv("MODE", mode, 1);
1599
if(ret == -1){
1600
perror_plus("setenv");
1601
_exit(EX_OSERR);
1602
}
1603
char *delaystring;
1604
ret = asprintf(&delaystring, "%f", (double)delay);
1605
if(ret == -1){
1606
perror_plus("asprintf");
1607
_exit(EX_OSERR);
1608
}
1609
ret = setenv("DELAY", delaystring, 1);
1610
if(ret == -1){
1611
free(delaystring);
1612
perror_plus("setenv");
1613
_exit(EX_OSERR);
1614
}
1626
1615
free(delaystring);
1627
perror_plus("setenv");
1628
_exit(EX_OSERR);
1629
}
1630
free(delaystring);
1631
if(connect_to != NULL){
1632
ret = setenv("CONNECT", connect_to, 1);
1633
if(ret == -1){
1634
perror_plus("setenv");
1635
_exit(EX_OSERR);
1636
}
1637
}
1638
int hook_fd = openat(hookdir_fd, direntry->d_name, O_RDONLY);
1639
if(hook_fd == -1){
1640
perror_plus("openat");
1641
_exit(EXIT_FAILURE);
1642
}
1643
if((int)TEMP_FAILURE_RETRY(close(hookdir_fd)) == -1){
1644
perror_plus("close");
1645
_exit(EXIT_FAILURE);
1646
}
1647
if(fexecve(hook_fd, (char *const []){ direntry->d_name, NULL },
1648
environ) == -1){
1649
perror_plus("fexecve");
1650
_exit(EXIT_FAILURE);
1651
}
1652
} else {
1653
if(hook_pid == -1){
1654
perror_plus("fork");
1655
free(direntry);
1656
continue;
1657
}
1658
int status;
1659
if(TEMP_FAILURE_RETRY(waitpid(hook_pid, &status, 0)) == -1){
1660
perror_plus("waitpid");
1661
free(direntry);
1662
continue;
1663
}
1664
if(WIFEXITED(status)){
1665
if(WEXITSTATUS(status) != 0){
1666
fprintf_plus(stderr, "Warning: network hook \"%s\" exited"
1667
" with status %d\n", direntry->d_name,
1668
WEXITSTATUS(status));
1669
free(direntry);
1670
continue;
1671
}
1672
} else if(WIFSIGNALED(status)){
1673
fprintf_plus(stderr, "Warning: network hook \"%s\" died by"
1674
" signal %d\n", direntry->d_name,
1675
WTERMSIG(status));
1676
free(direntry);
1677
continue;
1616
if(connect_to != NULL){
1617
ret = setenv("CONNECT", connect_to, 1);
1618
if(ret == -1){
1619
perror_plus("setenv");
1620
_exit(EX_OSERR);
1621
}
1622
}
1623
if(execl(fullname, direntry->d_name, mode, NULL) == -1){
1624
perror_plus("execl");
1625
_exit(EXIT_FAILURE);
1626
}
1678
1627
} else {
1679
fprintf_plus(stderr, "Warning: network hook \"%s\""
1680
" crashed\n", direntry->d_name);
1681
free(direntry);
1682
continue;
1683
}
1684
}
1685
if(debug){
1686
fprintf_plus(stderr, "Network hook \"%s\" ran successfully\n",
1687
direntry->d_name);
1688
}
1689
free(direntry);
1690
}
1691
free(direntries);
1692
if((int)TEMP_FAILURE_RETRY(close(hookdir_fd)) == -1){
1693
perror_plus("close");
1694
} else {
1695
hookdir_fd = -1;
1696
}
1697
close(devnull);
1628
int status;
1629
if(TEMP_FAILURE_RETRY(waitpid(hook_pid, &status, 0)) == -1){
1630
perror_plus("waitpid");
1631
free(fullname);
1632
continue;
1633
}
1634
if(WIFEXITED(status)){
1635
if(WEXITSTATUS(status) != 0){
1636
fprintf_plus(stderr, "Warning: network hook \"%s\" exited"
1637
" with status %d\n", direntry->d_name,
1638
WEXITSTATUS(status));
1639
free(fullname);
1640
continue;
1641
}
1642
} else if(WIFSIGNALED(status)){
1643
fprintf_plus(stderr, "Warning: network hook \"%s\" died by"
1644
" signal %d\n", direntry->d_name,
1645
WTERMSIG(status));
1646
free(fullname);
1647
continue;
1648
} else {
1649
fprintf_plus(stderr, "Warning: network hook \"%s\""
1650
" crashed\n", direntry->d_name);
1651
free(fullname);
1652
continue;
1653
}
1654
}
1655
free(fullname);
1656
if(debug){
1657
fprintf_plus(stderr, "Network hook \"%s\" ran successfully\n",
1658
direntry->d_name);
1659
}
1660
}
1661
close(devnull);
1662
}
1698
1663
}
1699
1664
1700
1665
__attribute__((nonnull, warn_unused_result))
1751
1716
/* Raise privileges */
1752
1717
ret_errno = raise_privileges();
1753
1718
if(ret_errno != 0){
1754
errno = ret_errno;
1755
1719
perror_plus("Failed to raise privileges");
1756
1720
}
1757
1721
1861
1825
/* Raise privileges */
1862
1826
ret_errno = raise_privileges();
1863
1827
if(ret_errno != 0){
1864
errno = ret_errno;
1865
1828
perror_plus("Failed to raise privileges");
1866
1829
}
1867
1830
1902
1865
int main(int argc, char *argv[]){
1903
1866
mandos_context mc = { .server = NULL, .dh_bits = 1024,
1904
1867
.priority = "SECURE256:!CTYPE-X.509:"
1905
"+CTYPE-OPENPGP:!RSA", .current_server = NULL,
1868
"+CTYPE-OPENPGP", .current_server = NULL,
1906
1869
.interfaces = NULL, .interfaces_size = 0 };
1907
1870
AvahiSServiceBrowser *sb = NULL;
1908
1871
error_t ret_errno;
2274
2237
2275
2238
/* If no interfaces were specified, make a list */
2276
2239
if(mc.interfaces == NULL){
2277
struct dirent **direntries = NULL;
2240
struct dirent **direntries;
2278
2241
/* Look for any good interfaces */
2279
2242
ret = scandir(sys_class_net, &direntries, good_interface,
2280
2243
alphasort);
2286
2249
if(ret_errno != 0){
2287
2250
errno = ret_errno;
2288
2251
perror_plus("argz_add");
2289
free(direntries[i]);
2290
2252
continue;
2291
2253
}
2292
2254
if(debug){
2293
2255
fprintf_plus(stderr, "Will use interface \"%s\"\n",
2294
2256
direntries[i]->d_name);
2295
2257
}
2296
free(direntries[i]);
2297
2258
}
2298
2259
free(direntries);
2299
2260
} else {
2300
if(ret == 0){
2301
free(direntries);
2302
}
2261
free(direntries);
2303
2262
fprintf_plus(stderr, "Could not find a network interface\n");
2304
2263
exitcode = EXIT_FAILURE;
2305
2264
goto end;
2527
2486
if(debug){
2528
2487
fprintf_plus(stderr, "Starting Avahi loop search\n");
2529
2488
}
2530
2489
2531
2490
ret = avahi_loop_with_timeout(simple_poll,
2532
2491
(int)(retry_interval * 1000), &mc);
2533
2492
if(debug){
2569
2528
mc.current_server->prev->next = NULL;
2570
2529
while(mc.current_server != NULL){
2571
2530
server *next = mc.current_server->next;
2572
#ifdef __GNUC__
2573
#pragma GCC diagnostic push
2574
#pragma GCC diagnostic ignored "-Wcast-qual"
2575
#endif
2576
free((char *)(mc.current_server->ip));
2577
#ifdef __GNUC__
2578
#pragma GCC diagnostic pop
2579
#endif
2580
2531
free(mc.current_server);
2581
2532
mc.current_server = next;
2582
2533
}
2586
2537
{
2587
2538
ret_errno = raise_privileges();
2588
2539
if(ret_errno != 0){
2589
errno = ret_errno;
2590
2540
perror_plus("Failed to raise privileges");
2591
2541
} else {
2592
2542
2615
2565
2616
2566
ret_errno = lower_privileges_permanently();
2617
2567
if(ret_errno != 0){
2618
errno = ret_errno;
2619
2568
perror_plus("Failed to lower privileges permanently");
2620
2569
}
2621
2570
}
2626
2575
/* Removes the GPGME temp directory and all files inside */
2627
2576
if(tempdir != NULL){
2628
2577
struct dirent **direntries = NULL;
2629
int tempdir_fd = (int)TEMP_FAILURE_RETRY(open(tempdir, O_RDONLY |
2630
O_NOFOLLOW));
2631
if(tempdir_fd == -1){
2632
perror_plus("open");
2633
} else {
2634
#ifdef __GLIBC__
2635
#if __GLIBC_PREREQ(2, 15)
2636
int numentries = scandirat(tempdir_fd, ".", &direntries,
2637
notdotentries, alphasort);
2638
#else /* not __GLIBC_PREREQ(2, 15) */
2639
int numentries = scandir(tempdir, &direntries, notdotentries,
2640
alphasort);
2641
#endif /* not __GLIBC_PREREQ(2, 15) */
2642
#else /* not __GLIBC__ */
2643
int numentries = scandir(tempdir, &direntries, notdotentries,
2644
alphasort);
2645
#endif /* not __GLIBC__ */
2646
if(numentries >= 0){
2647
for(int i = 0; i < numentries; i++){
2648
ret = unlinkat(tempdir_fd, direntries[i]->d_name, 0);
2649
if(ret == -1){
2650
fprintf_plus(stderr, "unlinkat(open(\"%s\", O_RDONLY),"
2651
" \"%s\", 0): %s\n", tempdir,
2652
direntries[i]->d_name, strerror(errno));
2653
}
2654
free(direntries[i]);
2655
}
2656
2657
/* need to clean even if 0 because man page doesn't specify */
2658
free(direntries);
2659
if(numentries == -1){
2660
perror_plus("scandir");
2661
}
2662
ret = rmdir(tempdir);
2663
if(ret == -1 and errno != ENOENT){
2664
perror_plus("rmdir");
2665
}
2578
struct dirent *direntry = NULL;
2579
int numentries = scandir(tempdir, &direntries, notdotentries,
2580
alphasort);
2581
if(numentries > 0){
2582
for(int i = 0; i < numentries; i++){
2583
direntry = direntries[i];
2584
char *fullname = NULL;
2585
ret = asprintf(&fullname, "%s/%s", tempdir,
2586
direntry->d_name);
2587
if(ret < 0){
2588
perror_plus("asprintf");
2589
continue;
2590
}
2591
ret = remove(fullname);
2592
if(ret == -1){
2593
fprintf_plus(stderr, "remove(\"%s\"): %s\n", fullname,
2594
strerror(errno));
2595
}
2596
free(fullname);
2666
2597
}
2667
TEMP_FAILURE_RETRY(close(tempdir_fd));
2598
}
2599
2600
/* need to clean even if 0 because man page doesn't specify */
2601
free(direntries);
2602
if(numentries == -1){
2603
perror_plus("scandir");
2604
}
2605
ret = rmdir(tempdir);
2606
if(ret == -1 and errno != ENOENT){
2607
perror_plus("rmdir");
2668
2608
}
2669
2609
}
2670
2610
Loggerhead is a web-based interface for Breezy
Version: 2.0.2.dev0