/mandos/release

To get this branch, use:
bzr branch http://bzr.recompile.se/loggerhead/mandos/release

« back to all changes in this revision

Viewing changes to plugins.d/mandos-client.c

* Makefile (run-server): Use "--no-dbus" unconditionally.

* initramfs-tools-script: Correct tests for writable "/conf/conf.d".

* mandos: Add process ID number to logging messages.
  (IPv6_TCPServer.server_bind): Use plain "raise".
  (main): Do not try to handle SIGSEGV; it does not work.  Use plain
         "raise".  Log KeyboardInterrupt and server exit.

Show diffs side-by-side

added added

removed removed

Lines of Context:
plugins.d/mandos-client.c
36
36
#define _GNU_SOURCE             /* TEMP_FAILURE_RETRY(), asprintf() */
37
37
 
38
38
#include <stdio.h>              /* fprintf(), stderr, fwrite(),
39
 
                                   stdout, ferror(), sscanf */
 
39
                                   stdout, ferror(), sscanf(),
 
40
                                   remove() */
40
41
#include <stdint.h>             /* uint16_t, uint32_t */
41
42
#include <stddef.h>             /* NULL, size_t, ssize_t */
42
43
#include <stdlib.h>             /* free(), EXIT_SUCCESS, EXIT_FAILURE,
60
61
#include <inttypes.h>           /* PRIu16, intmax_t, SCNdMAX */
61
62
#include <assert.h>             /* assert() */
62
63
#include <errno.h>              /* perror(), errno */
63
 
#include <time.h>               /* time(), nanosleep() */
 
64
#include <time.h>               /* nanosleep(), time() */
64
65
#include <net/if.h>             /* ioctl, ifreq, SIOCGIFFLAGS, IFF_UP,
65
66
                                   SIOCSIFFLAGS, if_indextoname(),
66
67
                                   if_nametoindex(), IF_NAMESIZE */
154
155
  
155
156
  
156
157
  /*
157
 
   * Helper function to insert pub and seckey to the enigne keyring.
 
158
   * Helper function to insert pub and seckey to the engine keyring.
158
159
   */
159
160
  bool import_key(const char *filename){
160
161
    int fd;
832
833
    gid_t gid;
833
834
    char *connect_to = NULL;
834
835
    char tempdir[] = "/tmp/mandosXXXXXX";
 
836
    bool tempdir_created = false;
835
837
    AvahiIfIndex if_index = AVAHI_IF_UNSPEC;
836
838
    const char *seckey = PATHDIR "/" SECKEY;
837
839
    const char *pubkey = PATHDIR "/" PUBKEY;
839
841
    mandos_context mc = { .simple_poll = NULL, .server = NULL,
840
842
                          .dh_bits = 1024, .priority = "SECURE256"
841
843
                          ":!CTYPE-X.509:+CTYPE-OPENPGP" };
842
 
    bool gnutls_initalized = false;
843
 
    bool gpgme_initalized = false;
 
844
    bool gnutls_initialized = false;
 
845
    bool gpgme_initialized = false;
844
846
    double delay = 2.5;
845
847
    
846
848
    {
941
943
    
942
944
    /* If the interface is down, bring it up */
943
945
    {
944
 
      // Lower kernel loglevel to KERN_NOTICE to avoid
945
 
      // KERN_INFO messages to mess up the prompt
 
946
      /* Lower kernel loglevel to KERN_NOTICE to avoid KERN_INFO
 
947
         messages to mess up the prompt */
946
948
      ret = klogctl(8, NULL, 5);
947
949
      if(ret == -1){
948
950
        perror("klogctl");
949
951
      }
950
 
 
 
952
      
951
953
      sd = socket(PF_INET6, SOCK_DGRAM, IPPROTO_IP);
952
954
      if(sd < 0) {
953
955
        perror("socket");
982
984
          goto end;
983
985
        }
984
986
      }
985
 
      // sleep checking until interface is running
 
987
      /* sleep checking until interface is running */
986
988
      for(int i=0; i < delay * 4; i++){
987
989
        ret = ioctl(sd, SIOCGIFFLAGS, &network);
988
990
        if(ret == -1){
997
999
      if(ret == -1){
998
1000
        perror("close");
999
1001
      }
1000
 
      // Restores kernel loglevel to default
 
1002
      /* Restores kernel loglevel to default */
1001
1003
      ret = klogctl(7, NULL, 0);
1002
1004
      if(ret == -1){
1003
1005
        perror("klogctl");
1007
1009
    uid = getuid();
1008
1010
    gid = getgid();
1009
1011
    
 
1012
    setgid(gid);
 
1013
    if(ret == -1){
 
1014
      perror("setgid");
 
1015
    }
 
1016
    
1010
1017
    ret = setuid(uid);
1011
1018
    if(ret == -1){
1012
1019
      perror("setuid");
1013
1020
    }
1014
1021
    
1015
 
    setgid(gid);
1016
 
    if(ret == -1){
1017
 
      perror("setgid");
1018
 
    }
1019
 
    
1020
1022
    ret = init_gnutls_global(&mc, pubkey, seckey);
1021
1023
    if(ret == -1){
1022
1024
      fprintf(stderr, "init_gnutls_global failed\n");
1023
1025
      exitcode = EXIT_FAILURE;
1024
1026
      goto end;
1025
1027
    } else {
1026
 
      gnutls_initalized = true;
 
1028
      gnutls_initialized = true;
1027
1029
    }
1028
1030
    
1029
1031
    if(mkdtemp(tempdir) == NULL){
1030
1032
      perror("mkdtemp");
1031
 
      tempdir[0] = '\0';
1032
1033
      goto end;
1033
1034
    }
 
1035
    tempdir_created = true;
1034
1036
    
1035
1037
    if(not init_gpgme(&mc, pubkey, seckey, tempdir)){
1036
 
      fprintf(stderr, "gpgme_initalized failed\n");
 
1038
      fprintf(stderr, "init_gpgme failed\n");
1037
1039
      exitcode = EXIT_FAILURE;
1038
1040
      goto end;
1039
1041
    } else {
1040
 
      gpgme_initalized = true;
 
1042
      gpgme_initialized = true;
1041
1043
    }
1042
1044
    
1043
1045
    if_index = (AvahiIfIndex) if_nametoindex(interface);
1044
1046
    if(if_index == 0){
1045
1047
      fprintf(stderr, "No such interface: \"%s\"\n", interface);
1046
 
      exit(EXIT_FAILURE);
 
1048
      exitcode = EXIT_FAILURE;
 
1049
      goto end;
1047
1050
    }
1048
1051
    
1049
1052
    if(connect_to != NULL){
1153
1156
    if(mc.simple_poll != NULL)
1154
1157
        avahi_simple_poll_free(mc.simple_poll);
1155
1158
    
1156
 
    if(gnutls_initalized){
 
1159
    if(gnutls_initialized){
1157
1160
      gnutls_certificate_free_credentials(mc.cred);
1158
1161
      gnutls_global_deinit();
1159
1162
      gnutls_dh_params_deinit(mc.dh_params);
1160
1163
    }
1161
1164
    
1162
 
    if(gpgme_initalized){
 
1165
    if(gpgme_initialized){
1163
1166
      gpgme_release(mc.ctx);
1164
1167
    }
1165
1168
    
1166
1169
    /* Removes the temp directory used by GPGME */
1167
 
    if(tempdir[0] != '\0'){
 
1170
    if(tempdir_created){
1168
1171
      DIR *d;
1169
1172
      struct dirent *direntry;
1170
1173
      d = opendir(tempdir);
1178
1181
          if(direntry == NULL){
1179
1182
            break;
1180
1183
          }
1181
 
          if(direntry->d_type == DT_REG){
1182
 
            char *fullname = NULL;
1183
 
            ret = asprintf(&fullname, "%s/%s", tempdir,
1184
 
                           direntry->d_name);
1185
 
            if(ret < 0){
1186
 
              perror("asprintf");
1187
 
              continue;
1188
 
            }
1189
 
            ret = unlink(fullname);
1190
 
            if(ret == -1){
1191
 
              fprintf(stderr, "unlink(\"%s\"): %s",
1192
 
                      fullname, strerror(errno));
1193
 
            }
1194
 
            free(fullname);
1195
 
          }
 
1184
          /* Skip "." and ".." */
 
1185
          if(direntry->d_name[0] == '.'
 
1186
             and (direntry->d_name[1] == '\0'
 
1187
                  or (direntry->d_name[1] == '.'
 
1188
                      and direntry->d_name[2] == '\0'))){
 
1189
            continue;
 
1190
          }
 
1191
          char *fullname = NULL;
 
1192
          ret = asprintf(&fullname, "%s/%s", tempdir,
 
1193
                         direntry->d_name);
 
1194
          if(ret < 0){
 
1195
            perror("asprintf");
 
1196
            continue;
 
1197
          }
 
1198
          ret = remove(fullname);
 
1199
          if(ret == -1){
 
1200
            fprintf(stderr, "remove(\"%s\"): %s\n", fullname,
 
1201
                    strerror(errno));
 
1202
          }
 
1203
          free(fullname);
1196
1204
        }
1197
1205
        closedir(d);
1198
1206
      }
1201
1209
        perror("rmdir");
1202
1210
      }
1203
1211
    }
1204
 
          
 
1212
    
1205
1213
    return exitcode;
1206
1214
}