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
258
static bool init_gpgme(const char *seckey, const char *pubkey,
 
262
259
                       const char *tempdir, mandos_context *mc){
 
263
260
  gpgme_error_t rc;
 
 
490
485
/* GnuTLS log function callback */
 
491
 
__attribute__((nonnull))
 
492
486
static void debuggnutls(__attribute__((unused)) int level,
 
493
487
                        const char* string){
 
494
488
  fprintf_plus(stderr, "GnuTLS: %s", string);
 
497
 
__attribute__((nonnull, warn_unused_result))
 
498
491
static int init_gnutls_global(const char *pubkeyfilename,
 
499
492
                              const char *seckeyfilename,
 
500
493
                              mandos_context *mc){
 
 
637
629
                      __attribute__((unused)) const char *txt){}
 
639
631
/* Called when a Mandos server is found */
 
640
 
__attribute__((nonnull, warn_unused_result))
 
641
632
static int start_mandos_communication(const char *ip, in_port_t port,
 
642
633
                                      AvahiIfIndex if_index,
 
643
634
                                      int af, mandos_context *mc){
 
 
1251
1239
 * corresponds to an acceptable network device.
 
1252
1240
 * (This function is passed to scandir(3) as a filter function.)
 
1254
 
__attribute__((nonnull, warn_unused_result))
 
1255
1242
int good_interface(const struct dirent *if_entry){
 
1256
1243
  if(if_entry->d_name[0] == '.'){
 
 
1276
1263
 * This function determines if a network interface is up.
 
1278
 
__attribute__((nonnull, warn_unused_result))
 
1279
1265
bool interface_is_up(const char *interface){
 
1280
1266
  struct ifreq ifr;
 
1281
1267
  if(not get_flags(interface, &ifr)){
 
 
1293
1279
 * This function determines if a network interface is running
 
1295
 
__attribute__((nonnull, warn_unused_result))
 
1296
1281
bool interface_is_running(const char *interface){
 
1297
1282
  struct ifreq ifr;
 
1298
1283
  if(not get_flags(interface, &ifr)){
 
 
1306
1291
  return (bool)(ifr.ifr_flags & IFF_RUNNING);
 
1309
 
__attribute__((nonnull, pure, warn_unused_result))
 
1310
1294
int notdotentries(const struct dirent *direntry){
 
1311
1295
  /* Skip "." and ".." */
 
1312
1296
  if(direntry->d_name[0] == '.'
 
 
1392
1374
    if(mc->current_server == NULL){
 
1394
1376
        fprintf_plus(stderr, "Wait until first server is found."
 
1395
1377
                     " No timeout!\n");
 
1397
1379
      ret = avahi_simple_poll_iterate(s, -1);
 
1400
1382
        fprintf_plus(stderr, "Check current_server if we should run"
 
1401
1383
                     " it, or wait\n");
 
 
1447
1429
      ret = avahi_simple_poll_iterate(s, (int)block_time);
 
1450
 
      if(ret > 0 or errno != EINTR){
 
 
1432
      if (ret > 0 or errno != EINTR){
 
1451
1433
        return (ret != 1) ? ret : 0;
 
 
1457
1439
/* Set effective uid to 0, return errno */
 
1458
 
__attribute__((warn_unused_result))
 
1459
1440
error_t raise_privileges(void){
 
1460
1441
  error_t old_errno = errno;
 
1461
1442
  error_t ret_errno = 0;
 
 
1470
1451
/* Set effective and real user ID to 0.  Return errno. */
 
1471
 
__attribute__((warn_unused_result))
 
1472
1452
error_t raise_privileges_permanently(void){
 
1473
1453
  error_t old_errno = errno;
 
1474
1454
  error_t ret_errno = raise_privileges();
 
 
1510
1488
  return ret_errno;
 
1513
 
__attribute__((nonnull))
 
1514
 
void run_network_hooks(const char *mode, const char *interface,
 
 
1491
bool run_network_hooks(const char *mode, const char *interface,
 
1515
1492
                       const float delay){
 
1516
1493
  struct dirent **direntries;
 
1517
1494
  int numhooks = scandir(hookdir, &direntries, runnable_hook,
 
 
1545
1522
      if(hook_pid == 0){
 
1547
1524
        /* Raise privileges */
 
1548
 
        if(raise_privileges_permanently() != 0){
 
1549
 
          perror_plus("Failed to raise privileges");
 
 
1525
        raise_privileges_permanently();
 
1552
1526
        /* Set group */
 
1554
1528
        ret = setgid(0);
 
1556
1530
          perror_plus("setgid");
 
1559
1532
        /* Reset supplementary groups */
 
1561
1534
        ret = setgroups(0, NULL);
 
1563
1536
          perror_plus("setgroups");
 
1566
 
        ret = dup2(devnull, STDIN_FILENO);
 
1568
 
          perror_plus("dup2(devnull, STDIN_FILENO)");
 
1571
 
        ret = close(devnull);
 
1573
 
          perror_plus("close");
 
1576
 
        ret = dup2(STDERR_FILENO, STDOUT_FILENO);
 
1578
 
          perror_plus("dup2(STDERR_FILENO, STDOUT_FILENO)");
 
 
1538
        dup2(devnull, STDIN_FILENO);
 
 
1540
        dup2(STDERR_FILENO, STDOUT_FILENO);
 
1581
1541
        ret = setenv("MANDOSNETHOOKDIR", hookdir, 1);
 
1583
1543
          perror_plus("setenv");
 
 
1659
1619
    close(devnull);
 
1663
 
__attribute__((nonnull, warn_unused_result))
 
1664
1624
error_t bring_up_interface(const char *const interface,
 
1665
1625
                           const float delay){
 
1666
1627
  error_t old_errno = errno;
 
 
1628
  error_t ret_errno = 0;
 
 
1629
  int ret, ret_setflags;
 
1668
1630
  struct ifreq network;
 
1669
1631
  unsigned int if_index = if_nametoindex(interface);
 
1670
1632
  if(if_index == 0){
 
 
1681
1643
  if(not interface_is_up(interface)){
 
1682
 
    error_t ret_errno = 0, ioctl_errno = 0;
 
1683
 
    if(not get_flags(interface, &network)){
 
 
1644
    if(not get_flags(interface, &network) and debug){
 
1684
1645
      ret_errno = errno;
 
1685
1646
      fprintf_plus(stderr, "Failed to get flags for interface "
 
1686
1647
                   "\"%s\"\n", interface);
 
1688
1648
      return ret_errno;
 
1690
 
    network.ifr_flags |= IFF_UP; /* set flag */
 
 
1650
    network.ifr_flags |= IFF_UP;
 
1692
 
    int sd = socket(PF_INET6, SOCK_DGRAM, IPPROTO_IP);
 
 
1652
    sd = socket(PF_INET6, SOCK_DGRAM, IPPROTO_IP);
 
1694
1654
      ret_errno = errno;
 
1695
1655
      perror_plus("socket");
 
1696
1656
      errno = old_errno;
 
1697
1657
      return ret_errno;
 
1701
 
      ret = (int)TEMP_FAILURE_RETRY(close(sd));
 
1703
 
        perror_plus("close");
 
1705
1662
      errno = old_errno;
 
 
1714
 
    /* Raise privileges */
 
1715
 
    ret_errno = raise_privileges();
 
1716
 
    bool restore_loglevel = false;
 
1718
 
      perror_plus("Failed to raise privileges");
 
 
1671
    /* Raise priviliges */
 
1720
1674
#ifdef __linux__
 
1723
 
      /* Lower kernel loglevel to KERN_NOTICE to avoid KERN_INFO
 
1724
 
         messages about the network interface to mess up the prompt */
 
1725
 
      ret_linux = klogctl(8, NULL, 5);
 
1726
 
      if(ret_linux == -1){
 
1727
 
        perror_plus("klogctl");
 
1729
 
        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");
 
1732
1683
#endif  /* __linux__ */
 
1733
 
    int ret_setflags = ioctl(sd, SIOCSIFFLAGS, &network);
 
1734
 
    ioctl_errno = errno;
 
 
1684
    ret_setflags = ioctl(sd, SIOCSIFFLAGS, &network);
 
1735
1686
#ifdef __linux__
 
1736
1687
    if(restore_loglevel){
 
1737
1688
      ret_linux = klogctl(7, NULL, 0);
 
 
1798
1741
  if(interface_is_up(interface)){
 
1799
 
    error_t ret_errno = 0, ioctl_errno = 0;
 
 
1742
    error_t ret_errno = 0;
 
1800
1743
    if(not get_flags(interface, &network) and debug){
 
1801
1744
      ret_errno = errno;
 
1802
1745
      fprintf_plus(stderr, "Failed to get flags for interface "
 
1803
1746
                   "\"%s\"\n", interface);
 
1805
1747
      return ret_errno;
 
1807
1749
    network.ifr_flags &= ~(short)IFF_UP; /* clear flag */
 
1809
1751
    int sd = socket(PF_INET6, SOCK_DGRAM, IPPROTO_IP);
 
1811
1753
      ret_errno = errno;
 
1812
1754
      perror_plus("socket");
 
1813
1755
      errno = old_errno;
 
 
1822
 
    /* Raise privileges */
 
1823
 
    ret_errno = raise_privileges();
 
1825
 
      perror_plus("Failed to raise privileges");
 
 
1764
    /* Raise priviliges */
 
1827
1767
    int ret_setflags = ioctl(sd, SIOCSIFFLAGS, &network);
 
1828
 
    ioctl_errno = errno;
 
1830
 
    /* If raise_privileges() succeeded above */
 
1832
 
      /* Lower privileges */
 
1833
 
      ret_errno = lower_privileges();
 
1836
 
        perror_plus("Failed to lower privileges");
 
 
1770
    /* Lower privileges */
 
1840
1773
    /* Close the socket */
 
1841
1774
    int ret = (int)TEMP_FAILURE_RETRY(close(sd));
 
 
1861
1794
int main(int argc, char *argv[]){
 
1862
1795
  mandos_context mc = { .server = NULL, .dh_bits = 1024,
 
1863
1796
                        .priority = "SECURE256:!CTYPE-X.509:"
 
1864
 
                        "+CTYPE-OPENPGP", .current_server = NULL,
 
 
1797
                        "+CTYPE-OPENPGP", .current_server = NULL, 
 
1865
1798
                        .interfaces = NULL, .interfaces_size = 0 };
 
1866
1799
  AvahiSServiceBrowser *sb = NULL;
 
1867
1800
  error_t ret_errno;
 
 
2060
1993
    /* Work around Debian bug #633582:
 
2061
1994
       <http://bugs.debian.org/633582> */
 
2063
 
    /* Re-raise privileges */
 
2064
 
    ret_errno = raise_privileges();
 
2067
 
      perror_plus("Failed to raise privileges");
 
 
1996
    /* Re-raise priviliges */
 
 
1997
    if(raise_privileges() == 0){
 
2069
1998
      struct stat st;
 
2071
2000
      if(strcmp(seckey, PATHDIR "/" SECKEY) == 0){
 
 
2147
2072
      memcpy(interfaces_hooks, mc.interfaces, mc.interfaces_size);
 
2148
2073
      argz_stringify(interfaces_hooks, mc.interfaces_size, (int)',');
 
2150
 
    run_network_hooks("start", interfaces_hooks != NULL ?
 
2151
 
                      interfaces_hooks : "", delay);
 
 
2075
    if(not run_network_hooks("start", interfaces_hooks != NULL ?
 
 
2076
                             interfaces_hooks : "", delay)){
 
 
2284
2211
      bool interface_was_up = interface_is_up(interface);
 
2285
 
      errno = bring_up_interface(interface, delay);
 
 
2212
      ret = bring_up_interface(interface, delay);
 
2286
2213
      if(not interface_was_up){
 
2288
2216
          perror_plus("Failed to bring up interface");
 
2290
 
          errno = argz_add(&interfaces_to_take_down,
 
2291
 
                           &interfaces_to_take_down_size,
 
 
2218
          ret_errno = argz_add(&interfaces_to_take_down,
 
 
2219
                               &interfaces_to_take_down_size,
 
2294
2223
            perror_plus("argz_add");
 
 
2523
 
  /* Re-raise privileges */
 
 
2452
  /* Re-raise priviliges */
 
2525
 
    ret_errno = raise_privileges();
 
2527
 
      perror_plus("Failed to raise privileges");
 
2530
 
      /* Run network hooks */
 
2531
 
      run_network_hooks("stop", interfaces_hooks != NULL ?
 
2532
 
                        interfaces_hooks : "", delay);
 
2534
 
      /* Take down the network interfaces which were brought up */
 
2536
 
        char *interface = NULL;
 
2537
 
        while((interface=argz_next(interfaces_to_take_down,
 
2538
 
                                   interfaces_to_take_down_size,
 
2540
 
          ret_errno = take_down_interface(interface);
 
2543
 
            perror_plus("Failed to take down interface");
 
2546
 
        if(debug and (interfaces_to_take_down == NULL)){
 
2547
 
          fprintf_plus(stderr, "No interfaces needed to be taken"
 
2552
 
    ret_errno = lower_privileges_permanently();
 
2554
 
      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();
 
2558
2481
  free(interfaces_to_take_down);
 
 
2564
2487
    struct dirent *direntry = NULL;
 
2565
2488
    int numentries = scandir(tempdir, &direntries, notdotentries,
 
 
2490
    if (numentries > 0){
 
2568
2491
      for(int i = 0; i < numentries; i++){
 
2569
2492
        direntry = direntries[i];
 
2570
2493
        char *fullname = NULL;