/mandos/trunk

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

  • Committer: Teddy Hogeborn
  • Date: 2009-04-17 08:26:17 UTC
  • Revision ID: teddy@fukt.bsnet.se-20090417082617-eltetak5lzjyz55o
* initramfs-tools-hook: Bug fix: Add "--userid" and "--groupid" to
                        start of "plugin-runner.conf" file instead of
                        appending, to allow any preexisting options to
                        override.
* plugin-runner.conf: Improved wording.

Show diffs side-by-side

added added

removed removed

Lines of Context:
plugins.d/mandos-client.c
80
80
                                   argp_parse(), ARGP_KEY_ARG,
81
81
                                   ARGP_KEY_END, ARGP_ERR_UNKNOWN */
82
82
#include <signal.h>             /* sigemptyset(), sigaddset(),
83
 
                                   sigaction(), SIGTERM, sig_atomic_t,
84
 
                                   raise() */
 
83
                                   sigaction(), SIGTERM, sigaction,
 
84
                                   sig_atomic_t */
85
85
 
86
86
#ifdef __linux__
87
87
#include <sys/klog.h>           /* klogctl() */
249
249
    return false;
250
250
  }
251
251
  
252
 
  return true;
 
252
  return true; 
253
253
}
254
254
 
255
255
/* 
309
309
        }
310
310
        gpgme_recipient_t recipient;
311
311
        recipient = result->recipients;
312
 
        while(recipient != NULL){
313
 
          fprintf(stderr, "Public key algorithm: %s\n",
314
 
                  gpgme_pubkey_algo_name(recipient->pubkey_algo));
315
 
          fprintf(stderr, "Key ID: %s\n", recipient->keyid);
316
 
          fprintf(stderr, "Secret key available: %s\n",
317
 
                  recipient->status == GPG_ERR_NO_SECKEY
318
 
                  ? "No" : "Yes");
319
 
          recipient = recipient->next;
 
312
        if(recipient){
 
313
          while(recipient != NULL){
 
314
            fprintf(stderr, "Public key algorithm: %s\n",
 
315
                    gpgme_pubkey_algo_name(recipient->pubkey_algo));
 
316
            fprintf(stderr, "Key ID: %s\n", recipient->keyid);
 
317
            fprintf(stderr, "Secret key available: %s\n",
 
318
                    recipient->status == GPG_ERR_NO_SECKEY
 
319
                    ? "No" : "Yes");
 
320
            recipient = recipient->next;
 
321
          }
320
322
        }
321
323
      }
322
324
    }
514
516
static void empty_log(__attribute__((unused)) AvahiLogLevel level,
515
517
                      __attribute__((unused)) const char *txt){}
516
518
 
517
 
sig_atomic_t quit_now = 0;
518
 
int signal_received = 0;
519
 
 
520
519
/* Called when a Mandos server is found */
521
520
static int start_mandos_communication(const char *ip, uint16_t port,
522
521
                                      AvahiIfIndex if_index,
802
801
  /* Called whenever a service has been resolved successfully or
803
802
     timed out */
804
803
  
805
 
  if(quit_now){
806
 
    return;
807
 
  }
808
 
  
809
804
  switch(event){
810
805
  default:
811
806
  case AVAHI_RESOLVER_FAILURE:
882
877
  }
883
878
}
884
879
 
 
880
sig_atomic_t quit_now = 0;
 
881
 
885
882
/* stop main loop after sigterm has been called */
886
 
static void handle_sigterm(int sig){
 
883
static void handle_sigterm(__attribute__((unused)) int sig){
887
884
  if(quit_now){
888
885
    return;
889
886
  }
890
887
  quit_now = 1;
891
 
  signal_received = sig;
892
888
  int old_errno = errno;
893
889
  if(mc.simple_poll != NULL){
894
890
    avahi_simple_poll_quit(mc.simple_poll);
905
901
  int exitcode = EXIT_SUCCESS;
906
902
  const char *interface = "eth0";
907
903
  struct ifreq network;
908
 
  int sd = -1;
909
 
  bool take_down_interface = false;
 
904
  int sd;
910
905
  uid_t uid;
911
906
  gid_t gid;
912
907
  char *connect_to = NULL;
1055
1050
    exitcode = EXIT_FAILURE;
1056
1051
    goto end;
1057
1052
  }
1058
 
  /* Need to check if the handler is SIG_IGN before handling:
1059
 
     | [[info:libc:Initial Signal Actions]] |
1060
 
     | [[info:libc:Basic Signal Handling]]  |
1061
 
  */
1062
 
  ret = sigaction(SIGINT, NULL, &old_sigterm_action);
1063
 
  if(ret == -1){
1064
 
    perror("sigaction");
1065
 
    return EXIT_FAILURE;
1066
 
  }
1067
 
  if(old_sigterm_action.sa_handler != SIG_IGN){
1068
 
    ret = sigaction(SIGINT, &sigterm_action, NULL);
1069
 
    if(ret == -1){
1070
 
      perror("sigaction");
1071
 
      exitcode = EXIT_FAILURE;
1072
 
      goto end;
1073
 
    }
1074
 
  }
1075
 
  ret = sigaction(SIGHUP, NULL, &old_sigterm_action);
1076
 
  if(ret == -1){
1077
 
    perror("sigaction");
1078
 
    return EXIT_FAILURE;
1079
 
  }
1080
 
  if(old_sigterm_action.sa_handler != SIG_IGN){
1081
 
    ret = sigaction(SIGHUP, &sigterm_action, NULL);
1082
 
    if(ret == -1){
1083
 
      perror("sigaction");
1084
 
      exitcode = EXIT_FAILURE;
1085
 
      goto end;
1086
 
    }
1087
 
  }
1088
 
  ret = sigaction(SIGTERM, NULL, &old_sigterm_action);
1089
 
  if(ret == -1){
1090
 
    perror("sigaction");
1091
 
    return EXIT_FAILURE;
1092
 
  }
1093
 
  if(old_sigterm_action.sa_handler != SIG_IGN){
1094
 
    ret = sigaction(SIGTERM, &sigterm_action, NULL);
1095
 
    if(ret == -1){
1096
 
      perror("sigaction");
1097
 
      exitcode = EXIT_FAILURE;
1098
 
      goto end;
1099
 
    }
1100
 
  }
 
1053
  ret = sigaction(SIGTERM, &sigterm_action, &old_sigterm_action);
 
1054
  if(ret == -1){
 
1055
    perror("sigaction");
 
1056
    exitcode = EXIT_FAILURE;
 
1057
    goto end;
 
1058
  }  
1101
1059
  
1102
1060
  /* If the interface is down, bring it up */
1103
1061
  if(interface[0] != '\0'){
1104
 
    if_index = (AvahiIfIndex) if_nametoindex(interface);
1105
 
    if(if_index == 0){
1106
 
      fprintf(stderr, "No such interface: \"%s\"\n", interface);
1107
 
      exitcode = EXIT_FAILURE;
1108
 
      goto end;
1109
 
    }
1110
 
    
1111
 
    if(quit_now){
1112
 
      goto end;
1113
 
    }
1114
 
    
1115
1062
#ifdef __linux__
1116
1063
    /* Lower kernel loglevel to KERN_NOTICE to avoid KERN_INFO
1117
1064
       messages to mess up the prompt */
1154
1101
    }
1155
1102
    if((network.ifr_flags & IFF_UP) == 0){
1156
1103
      network.ifr_flags |= IFF_UP;
1157
 
      take_down_interface = true;
1158
1104
      ret = ioctl(sd, SIOCSIFFLAGS, &network);
1159
1105
      if(ret == -1){
1160
 
        take_down_interface = false;
1161
1106
        perror("ioctl SIOCSIFFLAGS");
1162
1107
        exitcode = EXIT_FAILURE;
1163
1108
#ifdef __linux__
1185
1130
        perror("nanosleep");
1186
1131
      }
1187
1132
    }
1188
 
    if(not take_down_interface){
1189
 
      /* We won't need the socket anymore */
1190
 
      ret = (int)TEMP_FAILURE_RETRY(close(sd));
1191
 
      if(ret == -1){
1192
 
        perror("close");
1193
 
      }
 
1133
    ret = (int)TEMP_FAILURE_RETRY(close(sd));
 
1134
    if(ret == -1){
 
1135
      perror("close");
1194
1136
    }
1195
1137
#ifdef __linux__
1196
1138
    if(restore_loglevel){
1203
1145
#endif  /* __linux__ */
1204
1146
  }
1205
1147
  
1206
 
  if(quit_now){
1207
 
    goto end;
1208
 
  }
1209
 
  
1210
1148
  uid = getuid();
1211
1149
  gid = getgid();
1212
1150
  
1221
1159
    perror("setuid");
1222
1160
  }
1223
1161
  
1224
 
  if(quit_now){
1225
 
    goto end;
1226
 
  }
1227
 
  
1228
1162
  ret = init_gnutls_global(pubkey, seckey);
1229
1163
  if(ret == -1){
1230
1164
    fprintf(stderr, "init_gnutls_global failed\n");
1234
1168
    gnutls_initialized = true;
1235
1169
  }
1236
1170
  
1237
 
  if(quit_now){
1238
 
    goto end;
1239
 
  }
1240
 
  
1241
 
  tempdir_created = true;
1242
1171
  if(mkdtemp(tempdir) == NULL){
1243
 
    tempdir_created = false;
1244
1172
    perror("mkdtemp");
1245
1173
    goto end;
1246
1174
  }
1247
 
  
1248
 
  if(quit_now){
1249
 
    goto end;
1250
 
  }
 
1175
  tempdir_created = true;
1251
1176
  
1252
1177
  if(not init_gpgme(pubkey, seckey, tempdir)){
1253
1178
    fprintf(stderr, "init_gpgme failed\n");
1257
1182
    gpgme_initialized = true;
1258
1183
  }
1259
1184
  
1260
 
  if(quit_now){
1261
 
    goto end;
 
1185
  if(interface[0] != '\0'){
 
1186
    if_index = (AvahiIfIndex) if_nametoindex(interface);
 
1187
    if(if_index == 0){
 
1188
      fprintf(stderr, "No such interface: \"%s\"\n", interface);
 
1189
      exitcode = EXIT_FAILURE;
 
1190
      goto end;
 
1191
    }
1262
1192
  }
1263
1193
  
1264
1194
  if(connect_to != NULL){
1270
1200
      exitcode = EXIT_FAILURE;
1271
1201
      goto end;
1272
1202
    }
1273
 
    
1274
 
    if(quit_now){
1275
 
      goto end;
1276
 
    }
1277
 
    
1278
1203
    uint16_t port;
1279
1204
    errno = 0;
1280
1205
    tmpmax = strtoimax(address+1, &tmp, 10);
1284
1209
      exitcode = EXIT_FAILURE;
1285
1210
      goto end;
1286
1211
    }
1287
 
  
1288
 
    if(quit_now){
1289
 
      goto end;
1290
 
    }
1291
 
    
1292
1212
    port = (uint16_t)tmpmax;
1293
1213
    *address = '\0';
1294
1214
    address = connect_to;
1299
1219
    } else {
1300
1220
      af = AF_INET;
1301
1221
    }
1302
 
    
1303
 
    if(quit_now){
1304
 
      goto end;
1305
 
    }
1306
 
    
1307
1222
    ret = start_mandos_communication(address, port, if_index, af);
1308
1223
    if(ret < 0){
1309
1224
      exitcode = EXIT_FAILURE;
1312
1227
    }
1313
1228
    goto end;
1314
1229
  }
1315
 
  
1316
 
  if(quit_now){
1317
 
    goto end;
1318
 
  }
1319
 
  
 
1230
    
1320
1231
  {
1321
1232
    AvahiServerConfig config;
1322
1233
    /* Do not publish any local Zeroconf records */
1343
1254
    goto end;
1344
1255
  }
1345
1256
  
1346
 
  if(quit_now){
1347
 
    goto end;
1348
 
  }
1349
 
  
1350
1257
  /* Create the Avahi service browser */
1351
1258
  sb = avahi_s_service_browser_new(mc.server, if_index,
1352
1259
                                   AVAHI_PROTO_UNSPEC, "_mandos._tcp",
1358
1265
    goto end;
1359
1266
  }
1360
1267
  
1361
 
  if(quit_now){
1362
 
    goto end;
1363
 
  }
1364
 
  
1365
1268
  /* Run the main loop */
1366
1269
  
1367
1270
  if(debug){
1396
1299
    gpgme_release(mc.ctx);
1397
1300
  }
1398
1301
  
1399
 
  /* Take down the network interface */
1400
 
  if(take_down_interface){
1401
 
    ret = ioctl(sd, SIOCGIFFLAGS, &network);
1402
 
    if(ret == -1){
1403
 
      perror("ioctl SIOCGIFFLAGS");
1404
 
    } else if(network.ifr_flags & IFF_UP) {
1405
 
      network.ifr_flags &= ~IFF_UP; /* clear flag */
1406
 
      ret = ioctl(sd, SIOCSIFFLAGS, &network);
1407
 
      if(ret == -1){
1408
 
        perror("ioctl SIOCSIFFLAGS");
1409
 
      }
1410
 
    }
1411
 
    ret = (int)TEMP_FAILURE_RETRY(close(sd));
1412
 
    if(ret == -1){
1413
 
      perror("close");
1414
 
    }
1415
 
  }
1416
 
  
1417
1302
  /* Removes the temp directory used by GPGME */
1418
1303
  if(tempdir_created){
1419
1304
    DIR *d;
1458
1343
    }
1459
1344
  }
1460
1345
  
1461
 
  if(quit_now){
1462
 
    sigemptyset(&old_sigterm_action.sa_mask);
1463
 
    old_sigterm_action.sa_handler = SIG_DFL;
1464
 
    ret = sigaction(signal_received, &old_sigterm_action, NULL);
1465
 
    if(ret == -1){
1466
 
      perror("sigaction");
1467
 
    }
1468
 
    raise(signal_received);
1469
 
  }
1470
 
  
1471
1346
  return exitcode;
1472
1347
}