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 238
- compare with another revision
- download diff
- download tarball
- view history from revision 238
- Committer: Teddy Hogeborn
- Date: 2008-12-10 01:26:02 UTC
- mfrom: (237.1.2 mandos)
- Revision ID: teddy@fukt.bsnet.se-20081210012602-vhz3h75xkj24t340
First version of a somewhat complete D-Bus server interface. Also
change user/group name to "_mandos".
* debian/mandos.postinst: Rename old "mandos" user and group to
"_mandos"; create "_mandos" user and group
if none exist.
* debian/mandos-client.postinst: - '' -
* initramfs-tools-hook: Try "_mandos" before "mandos" as user and
group name.
* mandos (_datetime_to_dbus_struct): New; was previously local.
(Client.started): Renamed to "last_started". All users changed.
(Client.started): New; boolean.
(Client.dbus_object_path): New.
(Client.check_command): Renamed to "checker_command". All users
changed.
(Client.__init__): Set and use "self.dbus_object_path". Set
"self.started".
(Client.start): Update "self.started". Emit "self.PropertyChanged"
signals for both "started" and "last_started".
(Client.stop): Update "self.started". Emit "self.PropertyChanged"
signal for "started".
(Client.checker_callback): Take additional "command" argument. All
callers changed. Emit
"self.PropertyChanged" signal.
(Client.bump_timeout): Emit "self.PropertyChanged" signal for
"last_checked_ok".
(Client.start_checker): Emit "self.PropertyChanged" signal for
"checker_running".
(Client.stop_checker): Emit "self.PropertyChanged" signal for
"checker_running".
(Client.still_valid): Bug fix: use "getattr(self, started, False)"
instead of "self.started" in case this client
object is so new that the "started" attribute
has not been created yet.
(Client.IntervalChanged, Client.CheckerIsRunning, Client.GetChecker,
Client.GetCreated, Client.GetFingerprint, Client.GetHost,
Client.GetInterval, Client.GetName, Client.GetStarted,
Client.GetTimeout, Client.StateChanged, Client.TimeoutChanged):
Removed; all callers changed.
(Client.CheckerCompleted): Add "condition" and "command" arguments.
All callers changed.
(Client.GetAllProperties, Client.PropertyChanged): New.
(Client.StillValid): Renamed to "IsStillValid".
(Client.StartChecker): Changed to its own function to avoid the
return value from "Client.start_checker()".
(Client.Stop): Changed to its own function to avoid the return value
from "Client.stop()".
(main): Try "_mandos" before "mandos" as user and group name.
Removed inner function "remove_from_clients". New inner
class "MandosServer".
change user/group name to "_mandos".
* debian/mandos.postinst: Rename old "mandos" user and group to
"_mandos"; create "_mandos" user and group
if none exist.
* debian/mandos-client.postinst: - '' -
* initramfs-tools-hook: Try "_mandos" before "mandos" as user and
group name.
* mandos (_datetime_to_dbus_struct): New; was previously local.
(Client.started): Renamed to "last_started". All users changed.
(Client.started): New; boolean.
(Client.dbus_object_path): New.
(Client.check_command): Renamed to "checker_command". All users
changed.
(Client.__init__): Set and use "self.dbus_object_path". Set
"self.started".
(Client.start): Update "self.started". Emit "self.PropertyChanged"
signals for both "started" and "last_started".
(Client.stop): Update "self.started". Emit "self.PropertyChanged"
signal for "started".
(Client.checker_callback): Take additional "command" argument. All
callers changed. Emit
"self.PropertyChanged" signal.
(Client.bump_timeout): Emit "self.PropertyChanged" signal for
"last_checked_ok".
(Client.start_checker): Emit "self.PropertyChanged" signal for
"checker_running".
(Client.stop_checker): Emit "self.PropertyChanged" signal for
"checker_running".
(Client.still_valid): Bug fix: use "getattr(self, started, False)"
instead of "self.started" in case this client
object is so new that the "started" attribute
has not been created yet.
(Client.IntervalChanged, Client.CheckerIsRunning, Client.GetChecker,
Client.GetCreated, Client.GetFingerprint, Client.GetHost,
Client.GetInterval, Client.GetName, Client.GetStarted,
Client.GetTimeout, Client.StateChanged, Client.TimeoutChanged):
Removed; all callers changed.
(Client.CheckerCompleted): Add "condition" and "command" arguments.
All callers changed.
(Client.GetAllProperties, Client.PropertyChanged): New.
(Client.StillValid): Renamed to "IsStillValid".
(Client.StartChecker): Changed to its own function to avoid the
return value from "Client.start_checker()".
(Client.Stop): Changed to its own function to avoid the return value
from "Client.stop()".
(main): Try "_mandos" before "mandos" as user and group name.
Removed inner function "remove_from_clients". New inner
class "MandosServer".
- files added:
- debian/mandos-client.config
- files removed:
- DBUS-API
- debian/source
- files modified:
- .bzrignore
added
removed
plugins.d/mandos-client.c
1
1
/* -*- coding: utf-8 -*- */
2
2
/*
3
* Mandos-client - get and decrypt data from a Mandos server
3
* Mandos client - get and decrypt data from a Mandos server
4
4
*
5
5
* This program is partly derived from an example program for an Avahi
6
6
* service browser, downloaded from
9
9
* "browse_callback", and parts of "main".
10
10
*
11
11
* Everything else is
12
* Copyright © 2008-2011 Teddy Hogeborn
13
* Copyright © 2008-2011 Björn Påhlsson
12
* Copyright © 2008 Teddy Hogeborn
13
* Copyright © 2008 Björn Påhlsson
14
14
*
15
15
* This program is free software: you can redistribute it and/or
16
16
* modify it under the terms of the GNU General Public License as
30
30
*/
31
31
32
32
/* Needed by GPGME, specifically gpgme_data_seek() */
33
#ifndef _LARGEFILE_SOURCE
34
33
#define _LARGEFILE_SOURCE
35
#endif
36
#ifndef _FILE_OFFSET_BITS
37
34
#define _FILE_OFFSET_BITS 64
38
#endif
39
35
40
36
#define _GNU_SOURCE /* TEMP_FAILURE_RETRY(), asprintf() */
41
37
42
38
#include <stdio.h> /* fprintf(), stderr, fwrite(),
43
stdout, ferror(), remove() */
39
stdout, ferror() */
44
40
#include <stdint.h> /* uint16_t, uint32_t */
45
41
#include <stddef.h> /* NULL, size_t, ssize_t */
46
#include <stdlib.h> /* free(), EXIT_SUCCESS, srand(),
47
strtof(), abort() */
48
#include <stdbool.h> /* bool, false, true */
42
#include <stdlib.h> /* free(), EXIT_SUCCESS, EXIT_FAILURE,
43
srand() */
44
#include <stdbool.h> /* bool, true */
49
45
#include <string.h> /* memset(), strcmp(), strlen(),
50
46
strerror(), asprintf(), strcpy() */
51
#include <sys/ioctl.h> /* ioctl */
47
#include <sys/ioctl.h> /* ioctl */
52
48
#include <sys/types.h> /* socket(), inet_pton(), sockaddr,
53
49
sockaddr_in6, PF_INET6,
54
SOCK_STREAM, uid_t, gid_t, open(),
55
opendir(), DIR */
50
SOCK_STREAM, INET6_ADDRSTRLEN,
51
uid_t, gid_t, open(), opendir(), DIR */
56
52
#include <sys/stat.h> /* open() */
57
53
#include <sys/socket.h> /* socket(), struct sockaddr_in6,
58
inet_pton(), connect() */
54
struct in6_addr, inet_pton(),
55
connect() */
59
56
#include <fcntl.h> /* open() */
60
#include <dirent.h> /* opendir(), struct dirent, readdir()
61
*/
62
#include <inttypes.h> /* PRIu16, PRIdMAX, intmax_t,
63
strtoimax() */
57
#include <dirent.h> /* opendir(), struct dirent, readdir() */
58
#include <inttypes.h> /* PRIu16 */
64
59
#include <assert.h> /* assert() */
65
60
#include <errno.h> /* perror(), errno */
66
#include <time.h> /* nanosleep(), time(), sleep() */
61
#include <time.h> /* time() */
67
62
#include <net/if.h> /* ioctl, ifreq, SIOCGIFFLAGS, IFF_UP,
68
63
SIOCSIFFLAGS, if_indextoname(),
69
64
if_nametoindex(), IF_NAMESIZE */
70
#include <netinet/in.h> /* IN6_IS_ADDR_LINKLOCAL,
71
INET_ADDRSTRLEN, INET6_ADDRSTRLEN
72
*/
65
#include <netinet/in.h>
73
66
#include <unistd.h> /* close(), SEEK_SET, off_t, write(),
74
getuid(), getgid(), seteuid(),
75
setgid(), pause() */
76
#include <arpa/inet.h> /* inet_pton(), htons, inet_ntop() */
77
#include <iso646.h> /* not, or, and */
67
getuid(), getgid(), setuid(),
68
setgid() */
69
#include <arpa/inet.h> /* inet_pton(), htons */
70
#include <iso646.h> /* not, and */
78
71
#include <argp.h> /* struct argp_option, error_t, struct
79
72
argp_state, struct argp,
80
73
argp_parse(), ARGP_KEY_ARG,
81
74
ARGP_KEY_END, ARGP_ERR_UNKNOWN */
82
#include <signal.h> /* sigemptyset(), sigaddset(),
83
sigaction(), SIGTERM, sig_atomic_t,
84
raise() */
85
#include <sysexits.h> /* EX_OSERR, EX_USAGE, EX_UNAVAILABLE,
86
EX_NOHOST, EX_IOERR, EX_PROTOCOL */
87
88
#ifdef __linux__
89
#include <sys/klog.h> /* klogctl() */
90
#endif /* __linux__ */
91
75
92
76
/* Avahi */
93
77
/* All Avahi types, constants and functions
106
90
gnutls_*
107
91
init_gnutls_session(),
108
92
GNUTLS_* */
109
#include <gnutls/openpgp.h>
110
/* gnutls_certificate_set_openpgp_key_file(),
93
#include <gnutls/openpgp.h> /* gnutls_certificate_set_openpgp_key_file(),
111
94
GNUTLS_OPENPGP_FMT_BASE64 */
112
95
113
96
/* GPGME */
127
110
static const char mandos_protocol_version[] = "1";
128
111
const char *argp_program_version = "mandos-client " VERSION;
129
112
const char *argp_program_bug_address = "<mandos@fukt.bsnet.se>";
130
static const char sys_class_net[] = "/sys/class/net";
131
char *connect_to = NULL;
132
113
133
114
/* Used for passing in values through the Avahi callback functions */
134
115
typedef struct {
141
122
gpgme_ctx_t ctx;
142
123
} mandos_context;
143
124
144
/* global context so signal handler can reach it*/
145
mandos_context mc = { .simple_poll = NULL, .server = NULL,
146
.dh_bits = 1024, .priority = "SECURE256"
147
":!CTYPE-X.509:+CTYPE-OPENPGP" };
148
149
sig_atomic_t quit_now = 0;
150
int signal_received = 0;
151
152
125
/*
153
* Make additional room in "buffer" for at least BUFFER_SIZE more
154
* bytes. "buffer_capacity" is how much is currently allocated,
126
* Make room in "buffer" for at least BUFFER_SIZE additional bytes.
127
* "buffer_capacity" is how much is currently allocated,
155
128
* "buffer_length" is how much is already used.
156
129
*/
157
size_t incbuffer(char **buffer, size_t buffer_length,
130
size_t adjustbuffer(char **buffer, size_t buffer_length,
158
131
size_t buffer_capacity){
159
if(buffer_length + BUFFER_SIZE > buffer_capacity){
132
if (buffer_length + BUFFER_SIZE > buffer_capacity){
160
133
*buffer = realloc(*buffer, buffer_capacity + BUFFER_SIZE);
161
if(buffer == NULL){
134
if (buffer == NULL){
162
135
return 0;
163
136
}
164
137
buffer_capacity += BUFFER_SIZE;
169
142
/*
170
143
* Initialize GPGME.
171
144
*/
172
static bool init_gpgme(const char *seckey,
145
static bool init_gpgme(mandos_context *mc, const char *seckey,
173
146
const char *pubkey, const char *tempdir){
147
int ret;
174
148
gpgme_error_t rc;
175
149
gpgme_engine_info_t engine_info;
176
150
177
151
178
152
/*
179
* Helper function to insert pub and seckey to the engine keyring.
153
* Helper function to insert pub and seckey to the enigne keyring.
180
154
*/
181
155
bool import_key(const char *filename){
182
int ret;
183
156
int fd;
184
157
gpgme_data_t pgp_data;
185
158
186
fd = (int)TEMP_FAILURE_RETRY(open(filename, O_RDONLY));
159
fd = TEMP_FAILURE_RETRY(open(filename, O_RDONLY));
187
160
if(fd == -1){
188
161
perror("open");
189
162
return false;
190
163
}
191
164
192
165
rc = gpgme_data_new_from_fd(&pgp_data, fd);
193
if(rc != GPG_ERR_NO_ERROR){
166
if (rc != GPG_ERR_NO_ERROR){
194
167
fprintf(stderr, "bad gpgme_data_new_from_fd: %s: %s\n",
195
168
gpgme_strsource(rc), gpgme_strerror(rc));
196
169
return false;
197
170
}
198
171
199
rc = gpgme_op_import(mc.ctx, pgp_data);
200
if(rc != GPG_ERR_NO_ERROR){
172
rc = gpgme_op_import(mc->ctx, pgp_data);
173
if (rc != GPG_ERR_NO_ERROR){
201
174
fprintf(stderr, "bad gpgme_op_import: %s: %s\n",
202
175
gpgme_strsource(rc), gpgme_strerror(rc));
203
176
return false;
204
177
}
205
178
206
ret = (int)TEMP_FAILURE_RETRY(close(fd));
179
ret = TEMP_FAILURE_RETRY(close(fd));
207
180
if(ret == -1){
208
181
perror("close");
209
182
}
211
184
return true;
212
185
}
213
186
214
if(debug){
215
fprintf(stderr, "Initializing GPGME\n");
187
if (debug){
188
fprintf(stderr, "Initialize gpgme\n");
216
189
}
217
190
218
191
/* Init GPGME */
219
192
gpgme_check_version(NULL);
220
193
rc = gpgme_engine_check_version(GPGME_PROTOCOL_OpenPGP);
221
if(rc != GPG_ERR_NO_ERROR){
194
if (rc != GPG_ERR_NO_ERROR){
222
195
fprintf(stderr, "bad gpgme_engine_check_version: %s: %s\n",
223
196
gpgme_strsource(rc), gpgme_strerror(rc));
224
197
return false;
225
198
}
226
199
227
200
/* Set GPGME home directory for the OpenPGP engine only */
228
rc = gpgme_get_engine_info(&engine_info);
229
if(rc != GPG_ERR_NO_ERROR){
201
rc = gpgme_get_engine_info (&engine_info);
202
if (rc != GPG_ERR_NO_ERROR){
230
203
fprintf(stderr, "bad gpgme_get_engine_info: %s: %s\n",
231
204
gpgme_strsource(rc), gpgme_strerror(rc));
232
205
return false;
245
218
}
246
219
247
220
/* Create new GPGME "context" */
248
rc = gpgme_new(&(mc.ctx));
249
if(rc != GPG_ERR_NO_ERROR){
221
rc = gpgme_new(&(mc->ctx));
222
if (rc != GPG_ERR_NO_ERROR){
250
223
fprintf(stderr, "bad gpgme_new: %s: %s\n",
251
224
gpgme_strsource(rc), gpgme_strerror(rc));
252
225
return false;
253
226
}
254
227
255
if(not import_key(pubkey) or not import_key(seckey)){
228
if (not import_key(pubkey) or not import_key(seckey)){
256
229
return false;
257
230
}
258
231
259
return true;
232
return true;
260
233
}
261
234
262
235
/*
263
236
* Decrypt OpenPGP data.
264
237
* Returns -1 on error
265
238
*/
266
static ssize_t pgp_packet_decrypt(const char *cryptotext,
267
size_t crypto_size,
268
char **plaintext){
239
static ssize_t pgp_packet_decrypt (const mandos_context *mc,
240
const char *cryptotext,
241
size_t crypto_size,
242
char **plaintext){
269
243
gpgme_data_t dh_crypto, dh_plain;
270
244
gpgme_error_t rc;
271
245
ssize_t ret;
272
246
size_t plaintext_capacity = 0;
273
247
ssize_t plaintext_length = 0;
274
248
275
if(debug){
249
if (debug){
276
250
fprintf(stderr, "Trying to decrypt OpenPGP data\n");
277
251
}
278
252
279
253
/* Create new GPGME data buffer from memory cryptotext */
280
254
rc = gpgme_data_new_from_mem(&dh_crypto, cryptotext, crypto_size,
281
255
0);
282
if(rc != GPG_ERR_NO_ERROR){
256
if (rc != GPG_ERR_NO_ERROR){
283
257
fprintf(stderr, "bad gpgme_data_new_from_mem: %s: %s\n",
284
258
gpgme_strsource(rc), gpgme_strerror(rc));
285
259
return -1;
287
261
288
262
/* Create new empty GPGME data buffer for the plaintext */
289
263
rc = gpgme_data_new(&dh_plain);
290
if(rc != GPG_ERR_NO_ERROR){
264
if (rc != GPG_ERR_NO_ERROR){
291
265
fprintf(stderr, "bad gpgme_data_new: %s: %s\n",
292
266
gpgme_strsource(rc), gpgme_strerror(rc));
293
267
gpgme_data_release(dh_crypto);
296
270
297
271
/* Decrypt data from the cryptotext data buffer to the plaintext
298
272
data buffer */
299
rc = gpgme_op_decrypt(mc.ctx, dh_crypto, dh_plain);
300
if(rc != GPG_ERR_NO_ERROR){
273
rc = gpgme_op_decrypt(mc->ctx, dh_crypto, dh_plain);
274
if (rc != GPG_ERR_NO_ERROR){
301
275
fprintf(stderr, "bad gpgme_op_decrypt: %s: %s\n",
302
276
gpgme_strsource(rc), gpgme_strerror(rc));
303
277
plaintext_length = -1;
304
if(debug){
278
if (debug){
305
279
gpgme_decrypt_result_t result;
306
result = gpgme_op_decrypt_result(mc.ctx);
307
if(result == NULL){
280
result = gpgme_op_decrypt_result(mc->ctx);
281
if (result == NULL){
308
282
fprintf(stderr, "gpgme_op_decrypt_result failed\n");
309
283
} else {
310
284
fprintf(stderr, "Unsupported algorithm: %s\n",
316
290
}
317
291
gpgme_recipient_t recipient;
318
292
recipient = result->recipients;
319
while(recipient != NULL){
320
fprintf(stderr, "Public key algorithm: %s\n",
321
gpgme_pubkey_algo_name(recipient->pubkey_algo));
322
fprintf(stderr, "Key ID: %s\n", recipient->keyid);
323
fprintf(stderr, "Secret key available: %s\n",
324
recipient->status == GPG_ERR_NO_SECKEY
325
? "No" : "Yes");
326
recipient = recipient->next;
293
if(recipient){
294
while(recipient != NULL){
295
fprintf(stderr, "Public key algorithm: %s\n",
296
gpgme_pubkey_algo_name(recipient->pubkey_algo));
297
fprintf(stderr, "Key ID: %s\n", recipient->keyid);
298
fprintf(stderr, "Secret key available: %s\n",
299
recipient->status == GPG_ERR_NO_SECKEY
300
? "No" : "Yes");
301
recipient = recipient->next;
302
}
327
303
}
328
304
}
329
305
}
335
311
}
336
312
337
313
/* Seek back to the beginning of the GPGME plaintext data buffer */
338
if(gpgme_data_seek(dh_plain, (off_t)0, SEEK_SET) == -1){
314
if (gpgme_data_seek(dh_plain, (off_t) 0, SEEK_SET) == -1){
339
315
perror("gpgme_data_seek");
340
316
plaintext_length = -1;
341
317
goto decrypt_end;
343
319
344
320
*plaintext = NULL;
345
321
while(true){
346
plaintext_capacity = incbuffer(plaintext,
322
plaintext_capacity = adjustbuffer(plaintext,
347
323
(size_t)plaintext_length,
348
324
plaintext_capacity);
349
if(plaintext_capacity == 0){
350
perror("incbuffer");
325
if (plaintext_capacity == 0){
326
perror("adjustbuffer");
351
327
plaintext_length = -1;
352
328
goto decrypt_end;
353
329
}
355
331
ret = gpgme_data_read(dh_plain, *plaintext + plaintext_length,
356
332
BUFFER_SIZE);
357
333
/* Print the data, if any */
358
if(ret == 0){
334
if (ret == 0){
359
335
/* EOF */
360
336
break;
361
337
}
385
361
return plaintext_length;
386
362
}
387
363
388
static const char * safer_gnutls_strerror(int value){
389
const char *ret = gnutls_strerror(value); /* Spurious warning from
390
-Wunreachable-code */
391
if(ret == NULL)
364
static const char * safer_gnutls_strerror (int value) {
365
const char *ret = gnutls_strerror (value); /* Spurious warning */
366
if (ret == NULL)
392
367
ret = "(unknown)";
393
368
return ret;
394
369
}
399
374
fprintf(stderr, "GnuTLS: %s", string);
400
375
}
401
376
402
static int init_gnutls_global(const char *pubkeyfilename,
377
static int init_gnutls_global(mandos_context *mc,
378
const char *pubkeyfilename,
403
379
const char *seckeyfilename){
404
380
int ret;
405
381
408
384
}
409
385
410
386
ret = gnutls_global_init();
411
if(ret != GNUTLS_E_SUCCESS){
412
fprintf(stderr, "GnuTLS global_init: %s\n",
413
safer_gnutls_strerror(ret));
387
if (ret != GNUTLS_E_SUCCESS) {
388
fprintf (stderr, "GnuTLS global_init: %s\n",
389
safer_gnutls_strerror(ret));
414
390
return -1;
415
391
}
416
392
417
if(debug){
393
if (debug){
418
394
/* "Use a log level over 10 to enable all debugging options."
419
395
* - GnuTLS manual
420
396
*/
423
399
}
424
400
425
401
/* OpenPGP credentials */
426
ret = gnutls_certificate_allocate_credentials(&mc.cred);
427
if(ret != GNUTLS_E_SUCCESS){
428
fprintf(stderr, "GnuTLS memory error: %s\n",
429
safer_gnutls_strerror(ret));
430
gnutls_global_deinit();
402
gnutls_certificate_allocate_credentials(&mc->cred);
403
if (ret != GNUTLS_E_SUCCESS){
404
fprintf (stderr, "GnuTLS memory error: %s\n", /* Spurious
405
warning */
406
safer_gnutls_strerror(ret));
407
gnutls_global_deinit ();
431
408
return -1;
432
409
}
433
410
438
415
}
439
416
440
417
ret = gnutls_certificate_set_openpgp_key_file
441
(mc.cred, pubkeyfilename, seckeyfilename,
418
(mc->cred, pubkeyfilename, seckeyfilename,
442
419
GNUTLS_OPENPGP_FMT_BASE64);
443
if(ret != GNUTLS_E_SUCCESS){
420
if (ret != GNUTLS_E_SUCCESS) {
444
421
fprintf(stderr,
445
422
"Error[%d] while reading the OpenPGP key pair ('%s',"
446
423
" '%s')\n", ret, pubkeyfilename, seckeyfilename);
450
427
}
451
428
452
429
/* GnuTLS server initialization */
453
ret = gnutls_dh_params_init(&mc.dh_params);
454
if(ret != GNUTLS_E_SUCCESS){
455
fprintf(stderr, "Error in GnuTLS DH parameter initialization:"
456
" %s\n", safer_gnutls_strerror(ret));
430
ret = gnutls_dh_params_init(&mc->dh_params);
431
if (ret != GNUTLS_E_SUCCESS) {
432
fprintf (stderr, "Error in GnuTLS DH parameter initialization:"
433
" %s\n", safer_gnutls_strerror(ret));
457
434
goto globalfail;
458
435
}
459
ret = gnutls_dh_params_generate2(mc.dh_params, mc.dh_bits);
460
if(ret != GNUTLS_E_SUCCESS){
461
fprintf(stderr, "Error in GnuTLS prime generation: %s\n",
462
safer_gnutls_strerror(ret));
436
ret = gnutls_dh_params_generate2(mc->dh_params, mc->dh_bits);
437
if (ret != GNUTLS_E_SUCCESS) {
438
fprintf (stderr, "Error in GnuTLS prime generation: %s\n",
439
safer_gnutls_strerror(ret));
463
440
goto globalfail;
464
441
}
465
442
466
gnutls_certificate_set_dh_params(mc.cred, mc.dh_params);
443
gnutls_certificate_set_dh_params(mc->cred, mc->dh_params);
467
444
468
445
return 0;
469
446
470
447
globalfail:
471
448
472
gnutls_certificate_free_credentials(mc.cred);
449
gnutls_certificate_free_credentials(mc->cred);
473
450
gnutls_global_deinit();
474
gnutls_dh_params_deinit(mc.dh_params);
451
gnutls_dh_params_deinit(mc->dh_params);
475
452
return -1;
476
453
}
477
454
478
static int init_gnutls_session(gnutls_session_t *session){
455
static int init_gnutls_session(mandos_context *mc,
456
gnutls_session_t *session){
479
457
int ret;
480
458
/* GnuTLS session creation */
481
do {
482
ret = gnutls_init(session, GNUTLS_SERVER);
483
if(quit_now){
484
return -1;
485
}
486
} while(ret == GNUTLS_E_INTERRUPTED or ret == GNUTLS_E_AGAIN);
487
if(ret != GNUTLS_E_SUCCESS){
459
ret = gnutls_init(session, GNUTLS_SERVER);
460
if (ret != GNUTLS_E_SUCCESS){
488
461
fprintf(stderr, "Error in GnuTLS session initialization: %s\n",
489
462
safer_gnutls_strerror(ret));
490
463
}
491
464
492
465
{
493
466
const char *err;
494
do {
495
ret = gnutls_priority_set_direct(*session, mc.priority, &err);
496
if(quit_now){
497
gnutls_deinit(*session);
498
return -1;
499
}
500
} while(ret == GNUTLS_E_INTERRUPTED or ret == GNUTLS_E_AGAIN);
501
if(ret != GNUTLS_E_SUCCESS){
467
ret = gnutls_priority_set_direct(*session, mc->priority, &err);
468
if (ret != GNUTLS_E_SUCCESS) {
502
469
fprintf(stderr, "Syntax error at: %s\n", err);
503
470
fprintf(stderr, "GnuTLS error: %s\n",
504
471
safer_gnutls_strerror(ret));
505
gnutls_deinit(*session);
472
gnutls_deinit (*session);
506
473
return -1;
507
474
}
508
475
}
509
476
510
do {
511
ret = gnutls_credentials_set(*session, GNUTLS_CRD_CERTIFICATE,
512
mc.cred);
513
if(quit_now){
514
gnutls_deinit(*session);
515
return -1;
516
}
517
} while(ret == GNUTLS_E_INTERRUPTED or ret == GNUTLS_E_AGAIN);
518
if(ret != GNUTLS_E_SUCCESS){
477
ret = gnutls_credentials_set(*session, GNUTLS_CRD_CERTIFICATE,
478
mc->cred);
479
if (ret != GNUTLS_E_SUCCESS) {
519
480
fprintf(stderr, "Error setting GnuTLS credentials: %s\n",
520
481
safer_gnutls_strerror(ret));
521
gnutls_deinit(*session);
482
gnutls_deinit (*session);
522
483
return -1;
523
484
}
524
485
525
486
/* ignore client certificate if any. */
526
gnutls_certificate_server_set_request(*session, GNUTLS_CERT_IGNORE);
487
gnutls_certificate_server_set_request (*session,
488
GNUTLS_CERT_IGNORE);
527
489
528
gnutls_dh_set_prime_bits(*session, mc.dh_bits);
490
gnutls_dh_set_prime_bits (*session, mc->dh_bits);
529
491
530
492
return 0;
531
493
}
537
499
/* Called when a Mandos server is found */
538
500
static int start_mandos_communication(const char *ip, uint16_t port,
539
501
AvahiIfIndex if_index,
540
int af){
541
int ret, tcp_sd = -1;
542
ssize_t sret;
543
union {
544
struct sockaddr_in in;
545
struct sockaddr_in6 in6;
546
} to;
502
mandos_context *mc){
503
int ret, tcp_sd;
504
union { struct sockaddr in; struct sockaddr_in6 in6; } to;
547
505
char *buffer = NULL;
548
char *decrypted_buffer = NULL;
506
char *decrypted_buffer;
549
507
size_t buffer_length = 0;
550
508
size_t buffer_capacity = 0;
509
ssize_t decrypted_buffer_size;
551
510
size_t written;
552
int retval = -1;
511
int retval = 0;
512
char interface[IF_NAMESIZE];
553
513
gnutls_session_t session;
554
int pf; /* Protocol family */
555
556
errno = 0;
557
558
if(quit_now){
559
errno = EINTR;
560
return -1;
561
}
562
563
switch(af){
564
case AF_INET6:
565
pf = PF_INET6;
566
break;
567
case AF_INET:
568
pf = PF_INET;
569
break;
570
default:
571
fprintf(stderr, "Bad address family: %d\n", af);
572
errno = EINVAL;
573
return -1;
574
}
575
576
ret = init_gnutls_session(&session);
577
if(ret != 0){
514
515
ret = init_gnutls_session (mc, &session);
516
if (ret != 0){
578
517
return -1;
579
518
}
580
519
581
520
if(debug){
582
fprintf(stderr, "Setting up a TCP connection to %s, port %" PRIu16
521
fprintf(stderr, "Setting up a tcp connection to %s, port %" PRIu16
583
522
"\n", ip, port);
584
523
}
585
524
586
tcp_sd = socket(pf, SOCK_STREAM, 0);
587
if(tcp_sd < 0){
588
int e = errno;
525
tcp_sd = socket(PF_INET6, SOCK_STREAM, 0);
526
if(tcp_sd < 0) {
589
527
perror("socket");
590
errno = e;
591
goto mandos_end;
528
return -1;
592
529
}
593
530
594
if(quit_now){
595
errno = EINTR;
596
goto mandos_end;
531
if(debug){
532
if(if_indextoname((unsigned int)if_index, interface) == NULL){
533
perror("if_indextoname");
534
return -1;
535
}
536
fprintf(stderr, "Binding to interface %s\n", interface);
597
537
}
598
538
599
539
memset(&to, 0, sizeof(to));
600
if(af == AF_INET6){
601
to.in6.sin6_family = (sa_family_t)af;
602
ret = inet_pton(af, ip, &to.in6.sin6_addr);
603
} else { /* IPv4 */
604
to.in.sin_family = (sa_family_t)af;
605
ret = inet_pton(af, ip, &to.in.sin_addr);
606
}
607
if(ret < 0 ){
608
int e = errno;
540
to.in6.sin6_family = AF_INET6;
541
/* It would be nice to have a way to detect if we were passed an
542
IPv4 address here. Now we assume an IPv6 address. */
543
ret = inet_pton(AF_INET6, ip, &to.in6.sin6_addr);
544
if (ret < 0 ){
609
545
perror("inet_pton");
610
errno = e;
611
goto mandos_end;
546
return -1;
612
547
}
613
548
if(ret == 0){
614
int e = errno;
615
549
fprintf(stderr, "Bad address: %s\n", ip);
616
errno = e;
617
goto mandos_end;
618
}
619
if(af == AF_INET6){
620
to.in6.sin6_port = htons(port); /* Spurious warnings from
621
-Wconversion and
622
-Wunreachable-code */
623
624
if(IN6_IS_ADDR_LINKLOCAL /* Spurious warnings from */
625
(&to.in6.sin6_addr)){ /* -Wstrict-aliasing=2 or lower and
626
-Wunreachable-code*/
627
if(if_index == AVAHI_IF_UNSPEC){
628
fprintf(stderr, "An IPv6 link-local address is incomplete"
629
" without a network interface\n");
630
errno = EINVAL;
631
goto mandos_end;
632
}
633
/* Set the network interface number as scope */
634
to.in6.sin6_scope_id = (uint32_t)if_index;
635
}
636
} else {
637
to.in.sin_port = htons(port); /* Spurious warnings from
638
-Wconversion and
639
-Wunreachable-code */
640
}
550
return -1;
551
}
552
to.in6.sin6_port = htons(port); /* Spurious warning */
641
553
642
if(quit_now){
643
errno = EINTR;
644
goto mandos_end;
645
}
554
to.in6.sin6_scope_id = (uint32_t)if_index;
646
555
647
556
if(debug){
648
if(af == AF_INET6 and if_index != AVAHI_IF_UNSPEC){
649
char interface[IF_NAMESIZE];
650
if(if_indextoname((unsigned int)if_index, interface) == NULL){
651
perror("if_indextoname");
652
} else {
653
fprintf(stderr, "Connection to: %s%%%s, port %" PRIu16 "\n",
654
ip, interface, port);
655
}
656
} else {
657
fprintf(stderr, "Connection to: %s, port %" PRIu16 "\n", ip,
658
port);
659
}
660
char addrstr[(INET_ADDRSTRLEN > INET6_ADDRSTRLEN) ?
661
INET_ADDRSTRLEN : INET6_ADDRSTRLEN] = "";
662
const char *pcret;
663
if(af == AF_INET6){
664
pcret = inet_ntop(af, &(to.in6.sin6_addr), addrstr,
665
sizeof(addrstr));
666
} else {
667
pcret = inet_ntop(af, &(to.in.sin_addr), addrstr,
668
sizeof(addrstr));
669
}
670
if(pcret == NULL){
557
fprintf(stderr, "Connection to: %s, port %" PRIu16 "\n", ip,
558
port);
559
char addrstr[INET6_ADDRSTRLEN] = "";
560
if(inet_ntop(to.in6.sin6_family, &(to.in6.sin6_addr), addrstr,
561
sizeof(addrstr)) == NULL){
671
562
perror("inet_ntop");
672
563
} else {
673
564
if(strcmp(addrstr, ip) != 0){
676
567
}
677
568
}
678
569
679
if(quit_now){
680
errno = EINTR;
681
goto mandos_end;
682
}
683
684
if(af == AF_INET6){
685
ret = connect(tcp_sd, &to.in6, sizeof(to));
686
} else {
687
ret = connect(tcp_sd, &to.in, sizeof(to)); /* IPv4 */
688
}
689
if(ret < 0){
690
if ((errno != ECONNREFUSED and errno != ENETUNREACH) or debug){
691
int e = errno;
692
perror("connect");
693
errno = e;
694
}
695
goto mandos_end;
696
}
697
698
if(quit_now){
699
errno = EINTR;
700
goto mandos_end;
570
ret = connect(tcp_sd, &to.in, sizeof(to));
571
if (ret < 0){
572
perror("connect");
573
return -1;
701
574
}
702
575
703
576
const char *out = mandos_protocol_version;
704
577
written = 0;
705
while(true){
578
while (true){
706
579
size_t out_size = strlen(out);
707
ret = (int)TEMP_FAILURE_RETRY(write(tcp_sd, out + written,
580
ret = TEMP_FAILURE_RETRY(write(tcp_sd, out + written,
708
581
out_size - written));
709
if(ret == -1){
710
int e = errno;
582
if (ret == -1){
711
583
perror("write");
712
errno = e;
584
retval = -1;
713
585
goto mandos_end;
714
586
}
715
587
written += (size_t)ret;
716
588
if(written < out_size){
717
589
continue;
718
590
} else {
719
if(out == mandos_protocol_version){
591
if (out == mandos_protocol_version){
720
592
written = 0;
721
593
out = "\r\n";
722
594
} else {
723
595
break;
724
596
}
725
597
}
726
727
if(quit_now){
728
errno = EINTR;
729
goto mandos_end;
730
}
731
598
}
732
599
733
600
if(debug){
734
601
fprintf(stderr, "Establishing TLS session with %s\n", ip);
735
602
}
736
603
737
if(quit_now){
738
errno = EINTR;
739
goto mandos_end;
740
}
741
742
gnutls_transport_set_ptr(session, (gnutls_transport_ptr_t) tcp_sd);
743
744
if(quit_now){
745
errno = EINTR;
746
goto mandos_end;
747
}
748
749
do {
750
ret = gnutls_handshake(session);
751
if(quit_now){
752
errno = EINTR;
753
goto mandos_end;
754
}
604
gnutls_transport_set_ptr (session, (gnutls_transport_ptr_t) tcp_sd);
605
606
do{
607
ret = gnutls_handshake (session);
755
608
} while(ret == GNUTLS_E_AGAIN or ret == GNUTLS_E_INTERRUPTED);
756
609
757
if(ret != GNUTLS_E_SUCCESS){
610
if (ret != GNUTLS_E_SUCCESS){
758
611
if(debug){
759
612
fprintf(stderr, "*** GnuTLS Handshake failed ***\n");
760
gnutls_perror(ret);
613
gnutls_perror (ret);
761
614
}
762
errno = EPROTO;
615
retval = -1;
763
616
goto mandos_end;
764
617
}
765
618
766
619
/* Read OpenPGP packet that contains the wanted password */
767
620
768
621
if(debug){
769
fprintf(stderr, "Retrieving OpenPGP encrypted password from %s\n",
622
fprintf(stderr, "Retrieving pgp encrypted password from %s\n",
770
623
ip);
771
624
}
772
625
773
626
while(true){
774
775
if(quit_now){
776
errno = EINTR;
777
goto mandos_end;
778
}
779
780
buffer_capacity = incbuffer(&buffer, buffer_length,
627
buffer_capacity = adjustbuffer(&buffer, buffer_length,
781
628
buffer_capacity);
782
if(buffer_capacity == 0){
783
int e = errno;
784
perror("incbuffer");
785
errno = e;
786
goto mandos_end;
787
}
788
789
if(quit_now){
790
errno = EINTR;
791
goto mandos_end;
792
}
793
794
sret = gnutls_record_recv(session, buffer+buffer_length,
795
BUFFER_SIZE);
796
if(sret == 0){
629
if (buffer_capacity == 0){
630
perror("adjustbuffer");
631
retval = -1;
632
goto mandos_end;
633
}
634
635
ret = gnutls_record_recv(session, buffer+buffer_length,
636
BUFFER_SIZE);
637
if (ret == 0){
797
638
break;
798
639
}
799
if(sret < 0){
800
switch(sret){
640
if (ret < 0){
641
switch(ret){
801
642
case GNUTLS_E_INTERRUPTED:
802
643
case GNUTLS_E_AGAIN:
803
644
break;
804
645
case GNUTLS_E_REHANDSHAKE:
805
do {
806
ret = gnutls_handshake(session);
807
808
if(quit_now){
809
errno = EINTR;
810
goto mandos_end;
811
}
646
do{
647
ret = gnutls_handshake (session);
812
648
} while(ret == GNUTLS_E_AGAIN or ret == GNUTLS_E_INTERRUPTED);
813
if(ret < 0){
649
if (ret < 0){
814
650
fprintf(stderr, "*** GnuTLS Re-handshake failed ***\n");
815
gnutls_perror(ret);
816
errno = EPROTO;
651
gnutls_perror (ret);
652
retval = -1;
817
653
goto mandos_end;
818
654
}
819
655
break;
820
656
default:
821
657
fprintf(stderr, "Unknown error while reading data from"
822
658
" encrypted session with Mandos server\n");
823
gnutls_bye(session, GNUTLS_SHUT_RDWR);
824
errno = EIO;
659
retval = -1;
660
gnutls_bye (session, GNUTLS_SHUT_RDWR);
825
661
goto mandos_end;
826
662
}
827
663
} else {
828
buffer_length += (size_t) sret;
664
buffer_length += (size_t) ret;
829
665
}
830
666
}
831
667
833
669
fprintf(stderr, "Closing TLS session\n");
834
670
}
835
671
836
if(quit_now){
837
errno = EINTR;
838
goto mandos_end;
839
}
840
841
do {
842
ret = gnutls_bye(session, GNUTLS_SHUT_RDWR);
843
if(quit_now){
844
errno = EINTR;
845
goto mandos_end;
846
}
847
} while(ret == GNUTLS_E_AGAIN or ret == GNUTLS_E_INTERRUPTED);
848
849
if(buffer_length > 0){
850
ssize_t decrypted_buffer_size;
851
decrypted_buffer_size = pgp_packet_decrypt(buffer,
672
gnutls_bye (session, GNUTLS_SHUT_RDWR);
673
674
if (buffer_length > 0){
675
decrypted_buffer_size = pgp_packet_decrypt(mc, buffer,
852
676
buffer_length,
853
677
&decrypted_buffer);
854
if(decrypted_buffer_size >= 0){
855
678
if (decrypted_buffer_size >= 0){
856
679
written = 0;
857
680
while(written < (size_t) decrypted_buffer_size){
858
if(quit_now){
859
errno = EINTR;
860
goto mandos_end;
861
}
862
863
ret = (int)fwrite(decrypted_buffer + written, 1,
864
(size_t)decrypted_buffer_size - written,
865
stdout);
681
ret = (int)fwrite (decrypted_buffer + written, 1,
682
(size_t)decrypted_buffer_size - written,
683
stdout);
866
684
if(ret == 0 and ferror(stdout)){
867
int e = errno;
868
685
if(debug){
869
686
fprintf(stderr, "Error writing encrypted data: %s\n",
870
687
strerror(errno));
871
688
}
872
errno = e;
873
goto mandos_end;
689
retval = -1;
690
break;
874
691
}
875
692
written += (size_t)ret;
876
693
}
877
retval = 0;
694
free(decrypted_buffer);
695
} else {
696
retval = -1;
878
697
}
698
} else {
699
retval = -1;
879
700
}
880
701
881
702
/* Shutdown procedure */
882
703
883
704
mandos_end:
884
{
885
int e = errno;
886
free(decrypted_buffer);
887
free(buffer);
888
if(tcp_sd >= 0){
889
ret = (int)TEMP_FAILURE_RETRY(close(tcp_sd));
890
}
891
if(ret == -1){
892
if(e == 0){
893
e = errno;
894
}
895
perror("close");
896
}
897
gnutls_deinit(session);
898
if(quit_now){
899
e = EINTR;
900
retval = -1;
901
}
902
errno = e;
705
free(buffer);
706
ret = TEMP_FAILURE_RETRY(close(tcp_sd));
707
if(ret == -1){
708
perror("close");
903
709
}
710
gnutls_deinit (session);
904
711
return retval;
905
712
}
906
713
907
714
static void resolve_callback(AvahiSServiceResolver *r,
908
715
AvahiIfIndex interface,
909
AvahiProtocol proto,
716
AVAHI_GCC_UNUSED AvahiProtocol protocol,
910
717
AvahiResolverEvent event,
911
718
const char *name,
912
719
const char *type,
917
724
AVAHI_GCC_UNUSED AvahiStringList *txt,
918
725
AVAHI_GCC_UNUSED AvahiLookupResultFlags
919
726
flags,
920
AVAHI_GCC_UNUSED void* userdata){
727
void* userdata) {
728
mandos_context *mc = userdata;
921
729
assert(r);
922
730
923
731
/* Called whenever a service has been resolved successfully or
924
732
timed out */
925
733
926
if(quit_now){
927
return;
928
}
929
930
switch(event){
734
switch (event) {
931
735
default:
932
736
case AVAHI_RESOLVER_FAILURE:
933
737
fprintf(stderr, "(Avahi Resolver) Failed to resolve service '%s'"
934
738
" of type '%s' in domain '%s': %s\n", name, type, domain,
935
avahi_strerror(avahi_server_errno(mc.server)));
739
avahi_strerror(avahi_server_errno(mc->server)));
936
740
break;
937
741
938
742
case AVAHI_RESOLVER_FOUND:
941
745
avahi_address_snprint(ip, sizeof(ip), address);
942
746
if(debug){
943
747
fprintf(stderr, "Mandos server \"%s\" found on %s (%s, %"
944
PRIdMAX ") on port %" PRIu16 "\n", name, host_name,
945
ip, (intmax_t)interface, port);
748
PRIu16 ") on port %d\n", name, host_name, ip,
749
interface, port);
946
750
}
947
int ret = start_mandos_communication(ip, port, interface,
948
avahi_proto_to_af(proto));
949
if(ret == 0){
950
avahi_simple_poll_quit(mc.simple_poll);
751
int ret = start_mandos_communication(ip, port, interface, mc);
752
if (ret == 0){
753
avahi_simple_poll_quit(mc->simple_poll);
951
754
}
952
755
}
953
756
}
954
757
avahi_s_service_resolver_free(r);
955
758
}
956
759
957
static void browse_callback(AvahiSServiceBrowser *b,
958
AvahiIfIndex interface,
959
AvahiProtocol protocol,
960
AvahiBrowserEvent event,
961
const char *name,
962
const char *type,
963
const char *domain,
964
AVAHI_GCC_UNUSED AvahiLookupResultFlags
965
flags,
966
AVAHI_GCC_UNUSED void* userdata){
760
static void browse_callback( AvahiSServiceBrowser *b,
761
AvahiIfIndex interface,
762
AvahiProtocol protocol,
763
AvahiBrowserEvent event,
764
const char *name,
765
const char *type,
766
const char *domain,
767
AVAHI_GCC_UNUSED AvahiLookupResultFlags
768
flags,
769
void* userdata) {
770
mandos_context *mc = userdata;
967
771
assert(b);
968
772
969
773
/* Called whenever a new services becomes available on the LAN or
970
774
is removed from the LAN */
971
775
972
if(quit_now){
973
return;
974
}
975
976
switch(event){
776
switch (event) {
977
777
default:
978
778
case AVAHI_BROWSER_FAILURE:
979
779
980
780
fprintf(stderr, "(Avahi browser) %s\n",
981
avahi_strerror(avahi_server_errno(mc.server)));
982
avahi_simple_poll_quit(mc.simple_poll);
781
avahi_strerror(avahi_server_errno(mc->server)));
782
avahi_simple_poll_quit(mc->simple_poll);
983
783
return;
984
784
985
785
case AVAHI_BROWSER_NEW:
988
788
the callback function is called the Avahi server will free the
989
789
resolver for us. */
990
790
991
if(avahi_s_service_resolver_new(mc.server, interface, protocol,
992
name, type, domain, protocol, 0,
993
resolve_callback, NULL) == NULL)
791
if (!(avahi_s_service_resolver_new(mc->server, interface,
792
protocol, name, type, domain,
793
AVAHI_PROTO_INET6, 0,
794
resolve_callback, mc)))
994
795
fprintf(stderr, "Avahi: Failed to resolve service '%s': %s\n",
995
name, avahi_strerror(avahi_server_errno(mc.server)));
796
name, avahi_strerror(avahi_server_errno(mc->server)));
996
797
break;
997
798
998
799
case AVAHI_BROWSER_REMOVE:
1007
808
}
1008
809
}
1009
810
1010
/* stop main loop after sigterm has been called */
1011
static void handle_sigterm(int sig){
1012
if(quit_now){
1013
return;
1014
}
1015
quit_now = 1;
1016
signal_received = sig;
1017
int old_errno = errno;
1018
if(mc.simple_poll != NULL){
1019
avahi_simple_poll_quit(mc.simple_poll);
1020
}
1021
errno = old_errno;
1022
}
1023
1024
/*
1025
* This function determines if a directory entry in /sys/class/net
1026
* corresponds to an acceptable network device.
1027
* (This function is passed to scandir(3) as a filter function.)
1028
*/
1029
int good_interface(const struct dirent *if_entry){
1030
ssize_t ssret;
1031
char *flagname = NULL;
1032
if(if_entry->d_name[0] == '.'){
1033
return 0;
1034
}
1035
int ret = asprintf(&flagname, "%s/%s/flags", sys_class_net,
1036
if_entry->d_name);
1037
if(ret < 0){
1038
perror("asprintf");
1039
return 0;
1040
}
1041
int flags_fd = (int)TEMP_FAILURE_RETRY(open(flagname, O_RDONLY));
1042
if(flags_fd == -1){
1043
perror("open");
1044
free(flagname);
1045
return 0;
1046
}
1047
free(flagname);
1048
typedef short ifreq_flags; /* ifreq.ifr_flags in netdevice(7) */
1049
/* read line from flags_fd */
1050
ssize_t to_read = 2+(sizeof(ifreq_flags)*2)+1; /* "0x1003\n" */
1051
char *flagstring = malloc((size_t)to_read+1); /* +1 for final \0 */
1052
flagstring[(size_t)to_read] = '\0';
1053
if(flagstring == NULL){
1054
perror("malloc");
1055
close(flags_fd);
1056
return 0;
1057
}
1058
while(to_read > 0){
1059
ssret = (ssize_t)TEMP_FAILURE_RETRY(read(flags_fd, flagstring,
1060
(size_t)to_read));
1061
if(ssret == -1){
1062
perror("read");
1063
free(flagstring);
1064
close(flags_fd);
1065
return 0;
1066
}
1067
to_read -= ssret;
1068
if(ssret == 0){
1069
break;
1070
}
1071
}
1072
close(flags_fd);
1073
intmax_t tmpmax;
1074
char *tmp;
1075
errno = 0;
1076
tmpmax = strtoimax(flagstring, &tmp, 0);
1077
if(errno != 0 or tmp == flagstring or (*tmp != '\0'
1078
and not (isspace(*tmp)))
1079
or tmpmax != (ifreq_flags)tmpmax){
1080
if(debug){
1081
fprintf(stderr, "Invalid flags \"%s\" for interface \"%s\"\n",
1082
flagstring, if_entry->d_name);
1083
}
1084
free(flagstring);
1085
return 0;
1086
}
1087
free(flagstring);
1088
ifreq_flags flags = (ifreq_flags)tmpmax;
1089
/* Reject the loopback device */
1090
if(flags & IFF_LOOPBACK){
1091
if(debug){
1092
fprintf(stderr, "Rejecting loopback interface \"%s\"\n",
1093
if_entry->d_name);
1094
}
1095
return 0;
1096
}
1097
/* Accept point-to-point devices only if connect_to is specified */
1098
if(connect_to != NULL and (flags & IFF_POINTOPOINT)){
1099
if(debug){
1100
fprintf(stderr, "Accepting point-to-point interface \"%s\"\n",
1101
if_entry->d_name);
1102
}
1103
return 1;
1104
}
1105
/* Otherwise, reject non-broadcast-capable devices */
1106
if(not (flags & IFF_BROADCAST)){
1107
if(debug){
1108
fprintf(stderr, "Rejecting non-broadcast interface \"%s\"\n",
1109
if_entry->d_name);
1110
}
1111
return 0;
1112
}
1113
/* Reject non-ARP interfaces (including dummy interfaces) */
1114
if(flags & IFF_NOARP){
1115
if(debug){
1116
fprintf(stderr, "Rejecting non-ARP interface \"%s\"\n",
1117
if_entry->d_name);
1118
}
1119
return 0;
1120
}
1121
/* Accept this device */
1122
if(debug){
1123
fprintf(stderr, "Interface \"%s\" is acceptable\n",
1124
if_entry->d_name);
1125
}
1126
return 1;
1127
}
1128
1129
811
int main(int argc, char *argv[]){
1130
AvahiSServiceBrowser *sb = NULL;
1131
int error;
1132
int ret;
1133
intmax_t tmpmax;
1134
char *tmp;
1135
int exitcode = EXIT_SUCCESS;
1136
const char *interface = "";
1137
struct ifreq network;
1138
int sd = -1;
1139
bool take_down_interface = false;
1140
uid_t uid;
1141
gid_t gid;
1142
char tempdir[] = "/tmp/mandosXXXXXX";
1143
bool tempdir_created = false;
1144
AvahiIfIndex if_index = AVAHI_IF_UNSPEC;
1145
const char *seckey = PATHDIR "/" SECKEY;
1146
const char *pubkey = PATHDIR "/" PUBKEY;
1147
1148
bool gnutls_initialized = false;
1149
bool gpgme_initialized = false;
1150
float delay = 2.5f;
1151
1152
struct sigaction old_sigterm_action = { .sa_handler = SIG_DFL };
1153
struct sigaction sigterm_action = { .sa_handler = handle_sigterm };
1154
1155
uid = getuid();
1156
gid = getgid();
1157
1158
/* Lower any group privileges we might have, just to be safe */
1159
errno = 0;
1160
ret = setgid(gid);
1161
if(ret == -1){
1162
perror("setgid");
1163
}
1164
1165
/* Lower user privileges (temporarily) */
1166
errno = 0;
1167
ret = seteuid(uid);
1168
if(ret == -1){
1169
perror("seteuid");
1170
}
1171
1172
if(quit_now){
1173
goto end;
1174
}
1175
1176
{
1177
struct argp_option options[] = {
1178
{ .name = "debug", .key = 128,
1179
.doc = "Debug mode", .group = 3 },
1180
{ .name = "connect", .key = 'c',
1181
.arg = "ADDRESS:PORT",
1182
.doc = "Connect directly to a specific Mandos server",
1183
.group = 1 },
1184
{ .name = "interface", .key = 'i',
1185
.arg = "NAME",
1186
.doc = "Network interface that will be used to search for"
1187
" Mandos servers",
1188
.group = 1 },
1189
{ .name = "seckey", .key = 's',
1190
.arg = "FILE",
1191
.doc = "OpenPGP secret key file base name",
1192
.group = 1 },
1193
{ .name = "pubkey", .key = 'p',
1194
.arg = "FILE",
1195
.doc = "OpenPGP public key file base name",
1196
.group = 2 },
1197
{ .name = "dh-bits", .key = 129,
1198
.arg = "BITS",
1199
.doc = "Bit length of the prime number used in the"
1200
" Diffie-Hellman key exchange",
1201
.group = 2 },
1202
{ .name = "priority", .key = 130,
1203
.arg = "STRING",
1204
.doc = "GnuTLS priority string for the TLS handshake",
1205
.group = 1 },
1206
{ .name = "delay", .key = 131,
1207
.arg = "SECONDS",
1208
.doc = "Maximum delay to wait for interface startup",
1209
.group = 2 },
1210
/*
1211
* These reproduce what we would get without ARGP_NO_HELP
1212
*/
1213
{ .name = "help", .key = '?',
1214
.doc = "Give this help list", .group = -1 },
1215
{ .name = "usage", .key = -3,
1216
.doc = "Give a short usage message", .group = -1 },
1217
{ .name = "version", .key = 'V',
1218
.doc = "Print program version", .group = -1 },
1219
{ .name = NULL }
1220
};
1221
1222
error_t parse_opt(int key, char *arg,
1223
struct argp_state *state){
1224
errno = 0;
1225
switch(key){
1226
case 128: /* --debug */
1227
debug = true;
1228
break;
1229
case 'c': /* --connect */
1230
connect_to = arg;
1231
break;
1232
case 'i': /* --interface */
1233
interface = arg;
1234
break;
1235
case 's': /* --seckey */
1236
seckey = arg;
1237
break;
1238
case 'p': /* --pubkey */
1239
pubkey = arg;
1240
break;
1241
case 129: /* --dh-bits */
1242
errno = 0;
1243
tmpmax = strtoimax(arg, &tmp, 10);
1244
if(errno != 0 or tmp == arg or *tmp != '\0'
1245
or tmpmax != (typeof(mc.dh_bits))tmpmax){
1246
argp_error(state, "Bad number of DH bits");
1247
}
1248
mc.dh_bits = (typeof(mc.dh_bits))tmpmax;
1249
break;
1250
case 130: /* --priority */
1251
mc.priority = arg;
1252
break;
1253
case 131: /* --delay */
1254
errno = 0;
1255
delay = strtof(arg, &tmp);
1256
if(errno != 0 or tmp == arg or *tmp != '\0'){
1257
argp_error(state, "Bad delay");
1258
}
1259
break;
1260
/*
1261
* These reproduce what we would get without ARGP_NO_HELP
1262
*/
1263
case '?': /* --help */
1264
argp_state_help(state, state->out_stream,
1265
(ARGP_HELP_STD_HELP | ARGP_HELP_EXIT_ERR)
1266
& ~(unsigned int)ARGP_HELP_EXIT_OK);
1267
case -3: /* --usage */
1268
argp_state_help(state, state->out_stream,
1269
ARGP_HELP_USAGE | ARGP_HELP_EXIT_ERR);
1270
case 'V': /* --version */
1271
fprintf(state->out_stream, "%s\n", argp_program_version);
1272
exit(argp_err_exit_status);
1273
break;
1274
default:
1275
return ARGP_ERR_UNKNOWN;
1276
}
1277
return errno;
1278
}
1279
1280
struct argp argp = { .options = options, .parser = parse_opt,
1281
.args_doc = "",
1282
.doc = "Mandos client -- Get and decrypt"
1283
" passwords from a Mandos server" };
1284
ret = argp_parse(&argp, argc, argv,
1285
ARGP_IN_ORDER | ARGP_NO_HELP, 0, NULL);
1286
switch(ret){
1287
case 0:
1288
break;
1289
case ENOMEM:
1290
default:
1291
errno = ret;
1292
perror("argp_parse");
1293
exitcode = EX_OSERR;
1294
goto end;
1295
case EINVAL:
1296
exitcode = EX_USAGE;
1297
goto end;
1298
}
1299
}
1300
1301
if(not debug){
1302
avahi_set_log_function(empty_log);
1303
}
1304
1305
if(interface[0] == '\0'){
1306
struct dirent **direntries;
1307
ret = scandir(sys_class_net, &direntries, good_interface,
1308
alphasort);
1309
if(ret >= 1){
1310
/* Pick the first good interface */
1311
interface = strdup(direntries[0]->d_name);
1312
if(debug){
1313
fprintf(stderr, "Using interface \"%s\"\n", interface);
1314
}
1315
if(interface == NULL){
1316
perror("malloc");
1317
free(direntries);
1318
exitcode = EXIT_FAILURE;
1319
goto end;
1320
}
1321
free(direntries);
1322
} else {
1323
free(direntries);
1324
fprintf(stderr, "Could not find a network interface\n");
1325
exitcode = EXIT_FAILURE;
1326
goto end;
1327
}
1328
}
1329
1330
/* Initialize Avahi early so avahi_simple_poll_quit() can be called
1331
from the signal handler */
1332
/* Initialize the pseudo-RNG for Avahi */
1333
srand((unsigned int) time(NULL));
1334
mc.simple_poll = avahi_simple_poll_new();
1335
if(mc.simple_poll == NULL){
1336
fprintf(stderr, "Avahi: Failed to create simple poll object.\n");
1337
exitcode = EX_UNAVAILABLE;
1338
goto end;
1339
}
1340
1341
sigemptyset(&sigterm_action.sa_mask);
1342
ret = sigaddset(&sigterm_action.sa_mask, SIGINT);
1343
if(ret == -1){
1344
perror("sigaddset");
1345
exitcode = EX_OSERR;
1346
goto end;
1347
}
1348
ret = sigaddset(&sigterm_action.sa_mask, SIGHUP);
1349
if(ret == -1){
1350
perror("sigaddset");
1351
exitcode = EX_OSERR;
1352
goto end;
1353
}
1354
ret = sigaddset(&sigterm_action.sa_mask, SIGTERM);
1355
if(ret == -1){
1356
perror("sigaddset");
1357
exitcode = EX_OSERR;
1358
goto end;
1359
}
1360
/* Need to check if the handler is SIG_IGN before handling:
1361
| [[info:libc:Initial Signal Actions]] |
1362
| [[info:libc:Basic Signal Handling]] |
1363
*/
1364
ret = sigaction(SIGINT, NULL, &old_sigterm_action);
1365
if(ret == -1){
1366
perror("sigaction");
1367
return EX_OSERR;
1368
}
1369
if(old_sigterm_action.sa_handler != SIG_IGN){
1370
ret = sigaction(SIGINT, &sigterm_action, NULL);
1371
if(ret == -1){
1372
perror("sigaction");
1373
exitcode = EX_OSERR;
1374
goto end;
1375
}
1376
}
1377
ret = sigaction(SIGHUP, NULL, &old_sigterm_action);
1378
if(ret == -1){
1379
perror("sigaction");
1380
return EX_OSERR;
1381
}
1382
if(old_sigterm_action.sa_handler != SIG_IGN){
1383
ret = sigaction(SIGHUP, &sigterm_action, NULL);
1384
if(ret == -1){
1385
perror("sigaction");
1386
exitcode = EX_OSERR;
1387
goto end;
1388
}
1389
}
1390
ret = sigaction(SIGTERM, NULL, &old_sigterm_action);
1391
if(ret == -1){
1392
perror("sigaction");
1393
return EX_OSERR;
1394
}
1395
if(old_sigterm_action.sa_handler != SIG_IGN){
1396
ret = sigaction(SIGTERM, &sigterm_action, NULL);
1397
if(ret == -1){
1398
perror("sigaction");
1399
exitcode = EX_OSERR;
1400
goto end;
1401
}
1402
}
1403
1404
/* If the interface is down, bring it up */
1405
if(strcmp(interface, "none") != 0){
812
AvahiSServiceBrowser *sb = NULL;
813
int error;
814
int ret;
815
int exitcode = EXIT_SUCCESS;
816
const char *interface = "eth0";
817
struct ifreq network;
818
int sd;
819
uid_t uid;
820
gid_t gid;
821
char *connect_to = NULL;
822
char tempdir[] = "/tmp/mandosXXXXXX";
823
AvahiIfIndex if_index = AVAHI_IF_UNSPEC;
824
const char *seckey = PATHDIR "/" SECKEY;
825
const char *pubkey = PATHDIR "/" PUBKEY;
826
827
mandos_context mc = { .simple_poll = NULL, .server = NULL,
828
.dh_bits = 1024, .priority = "SECURE256"
829
":!CTYPE-X.509:+CTYPE-OPENPGP" };
830
bool gnutls_initalized = false;
831
bool gpgme_initalized = false;
832
833
{
834
struct argp_option options[] = {
835
{ .name = "debug", .key = 128,
836
.doc = "Debug mode", .group = 3 },
837
{ .name = "connect", .key = 'c',
838
.arg = "ADDRESS:PORT",
839
.doc = "Connect directly to a specific Mandos server",
840
.group = 1 },
841
{ .name = "interface", .key = 'i',
842
.arg = "NAME",
843
.doc = "Interface that will be used to search for Mandos"
844
" servers",
845
.group = 1 },
846
{ .name = "seckey", .key = 's',
847
.arg = "FILE",
848
.doc = "OpenPGP secret key file base name",
849
.group = 1 },
850
{ .name = "pubkey", .key = 'p',
851
.arg = "FILE",
852
.doc = "OpenPGP public key file base name",
853
.group = 2 },
854
{ .name = "dh-bits", .key = 129,
855
.arg = "BITS",
856
.doc = "Bit length of the prime number used in the"
857
" Diffie-Hellman key exchange",
858
.group = 2 },
859
{ .name = "priority", .key = 130,
860
.arg = "STRING",
861
.doc = "GnuTLS priority string for the TLS handshake",
862
.group = 1 },
863
{ .name = NULL }
864
};
865
866
error_t parse_opt (int key, char *arg,
867
struct argp_state *state) {
868
/* Get the INPUT argument from `argp_parse', which we know is
869
a pointer to our plugin list pointer. */
870
switch (key) {
871
case 128: /* --debug */
872
debug = true;
873
break;
874
case 'c': /* --connect */
875
connect_to = arg;
876
break;
877
case 'i': /* --interface */
878
interface = arg;
879
break;
880
case 's': /* --seckey */
881
seckey = arg;
882
break;
883
case 'p': /* --pubkey */
884
pubkey = arg;
885
break;
886
case 129: /* --dh-bits */
887
errno = 0;
888
mc.dh_bits = (unsigned int) strtol(arg, NULL, 10);
889
if (errno){
890
perror("strtol");
891
exit(EXIT_FAILURE);
892
}
893
break;
894
case 130: /* --priority */
895
mc.priority = arg;
896
break;
897
case ARGP_KEY_ARG:
898
argp_usage (state);
899
case ARGP_KEY_END:
900
break;
901
default:
902
return ARGP_ERR_UNKNOWN;
903
}
904
return 0;
905
}
906
907
struct argp argp = { .options = options, .parser = parse_opt,
908
.args_doc = "",
909
.doc = "Mandos client -- Get and decrypt"
910
" passwords from a Mandos server" };
911
ret = argp_parse (&argp, argc, argv, 0, 0, NULL);
912
if (ret == ARGP_ERR_UNKNOWN){
913
fprintf(stderr, "Unknown error while parsing arguments\n");
914
exitcode = EXIT_FAILURE;
915
goto end;
916
}
917
}
918
919
/* If the interface is down, bring it up */
920
{
921
sd = socket(PF_INET6, SOCK_DGRAM, IPPROTO_IP);
922
if(sd < 0) {
923
perror("socket");
924
exitcode = EXIT_FAILURE;
925
goto end;
926
}
927
strcpy(network.ifr_name, interface);
928
ret = ioctl(sd, SIOCGIFFLAGS, &network);
929
if(ret == -1){
930
perror("ioctl SIOCGIFFLAGS");
931
exitcode = EXIT_FAILURE;
932
goto end;
933
}
934
if((network.ifr_flags & IFF_UP) == 0){
935
network.ifr_flags |= IFF_UP;
936
ret = ioctl(sd, SIOCSIFFLAGS, &network);
937
if(ret == -1){
938
perror("ioctl SIOCSIFFLAGS");
939
exitcode = EXIT_FAILURE;
940
goto end;
941
}
942
}
943
ret = TEMP_FAILURE_RETRY(close(sd));
944
if(ret == -1){
945
perror("close");
946
}
947
}
948
949
uid = getuid();
950
gid = getgid();
951
952
ret = setuid(uid);
953
if (ret == -1){
954
perror("setuid");
955
}
956
957
setgid(gid);
958
if (ret == -1){
959
perror("setgid");
960
}
961
962
ret = init_gnutls_global(&mc, pubkey, seckey);
963
if (ret == -1){
964
fprintf(stderr, "init_gnutls_global failed\n");
965
exitcode = EXIT_FAILURE;
966
goto end;
967
} else {
968
gnutls_initalized = true;
969
}
970
971
if(mkdtemp(tempdir) == NULL){
972
perror("mkdtemp");
973
tempdir[0] = '\0';
974
goto end;
975
}
976
977
if(not init_gpgme(&mc, pubkey, seckey, tempdir)){
978
fprintf(stderr, "gpgme_initalized failed\n");
979
exitcode = EXIT_FAILURE;
980
goto end;
981
} else {
982
gpgme_initalized = true;
983
}
984
1406
985
if_index = (AvahiIfIndex) if_nametoindex(interface);
1407
986
if(if_index == 0){
1408
987
fprintf(stderr, "No such interface: \"%s\"\n", interface);
1409
exitcode = EX_UNAVAILABLE;
1410
goto end;
1411
}
1412
1413
if(quit_now){
1414
goto end;
1415
}
1416
1417
/* Re-raise priviliges */
1418
errno = 0;
1419
ret = seteuid(0);
1420
if(ret == -1){
1421
perror("seteuid");
1422
}
1423
1424
#ifdef __linux__
1425
/* Lower kernel loglevel to KERN_NOTICE to avoid KERN_INFO
1426
messages about the network interface to mess up the prompt */
1427
ret = klogctl(8, NULL, 5);
1428
bool restore_loglevel = true;
1429
if(ret == -1){
1430
restore_loglevel = false;
1431
perror("klogctl");
1432
}
1433
#endif /* __linux__ */
1434
1435
sd = socket(PF_INET6, SOCK_DGRAM, IPPROTO_IP);
1436
if(sd < 0){
1437
perror("socket");
1438
exitcode = EX_OSERR;
1439
#ifdef __linux__
1440
if(restore_loglevel){
1441
ret = klogctl(7, NULL, 0);
1442
if(ret == -1){
1443
perror("klogctl");
1444
}
1445
}
1446
#endif /* __linux__ */
1447
/* Lower privileges */
1448
errno = 0;
1449
ret = seteuid(uid);
1450
if(ret == -1){
1451
perror("seteuid");
1452
}
1453
goto end;
1454
}
1455
strcpy(network.ifr_name, interface);
1456
ret = ioctl(sd, SIOCGIFFLAGS, &network);
1457
if(ret == -1){
1458
perror("ioctl SIOCGIFFLAGS");
1459
#ifdef __linux__
1460
if(restore_loglevel){
1461
ret = klogctl(7, NULL, 0);
1462
if(ret == -1){
1463
perror("klogctl");
1464
}
1465
}
1466
#endif /* __linux__ */
1467
exitcode = EX_OSERR;
1468
/* Lower privileges */
1469
errno = 0;
1470
ret = seteuid(uid);
1471
if(ret == -1){
1472
perror("seteuid");
1473
}
1474
goto end;
1475
}
1476
if((network.ifr_flags & IFF_UP) == 0){
1477
network.ifr_flags |= IFF_UP;
1478
take_down_interface = true;
1479
ret = ioctl(sd, SIOCSIFFLAGS, &network);
1480
if(ret == -1){
1481
take_down_interface = false;
1482
perror("ioctl SIOCSIFFLAGS +IFF_UP");
1483
exitcode = EX_OSERR;
1484
#ifdef __linux__
1485
if(restore_loglevel){
1486
ret = klogctl(7, NULL, 0);
1487
if(ret == -1){
1488
perror("klogctl");
1489
}
1490
}
1491
#endif /* __linux__ */
1492
/* Lower privileges */
1493
errno = 0;
1494
ret = seteuid(uid);
1495
if(ret == -1){
1496
perror("seteuid");
1497
}
1498
goto end;
1499
}
1500
}
1501
/* sleep checking until interface is running */
1502
for(int i=0; i < delay * 4; i++){
1503
ret = ioctl(sd, SIOCGIFFLAGS, &network);
1504
if(ret == -1){
1505
perror("ioctl SIOCGIFFLAGS");
1506
} else if(network.ifr_flags & IFF_RUNNING){
1507
break;
1508
}
1509
struct timespec sleeptime = { .tv_nsec = 250000000 };
1510
ret = nanosleep(&sleeptime, NULL);
1511
if(ret == -1 and errno != EINTR){
1512
perror("nanosleep");
1513
}
1514
}
1515
if(not take_down_interface){
1516
/* We won't need the socket anymore */
1517
ret = (int)TEMP_FAILURE_RETRY(close(sd));
1518
if(ret == -1){
1519
perror("close");
1520
}
1521
}
1522
#ifdef __linux__
1523
if(restore_loglevel){
1524
/* Restores kernel loglevel to default */
1525
ret = klogctl(7, NULL, 0);
1526
if(ret == -1){
1527
perror("klogctl");
1528
}
1529
}
1530
#endif /* __linux__ */
1531
/* Lower privileges */
1532
errno = 0;
1533
if(take_down_interface){
1534
/* Lower privileges */
1535
ret = seteuid(uid);
1536
if(ret == -1){
1537
perror("seteuid");
1538
}
1539
} else {
1540
/* Lower privileges permanently */
1541
ret = setuid(uid);
1542
if(ret == -1){
1543
perror("setuid");
1544
}
1545
}
1546
}
1547
1548
if(quit_now){
1549
goto end;
1550
}
1551
1552
ret = init_gnutls_global(pubkey, seckey);
1553
if(ret == -1){
1554
fprintf(stderr, "init_gnutls_global failed\n");
1555
exitcode = EX_UNAVAILABLE;
1556
goto end;
1557
} else {
1558
gnutls_initialized = true;
1559
}
1560
1561
if(quit_now){
1562
goto end;
1563
}
1564
1565
tempdir_created = true;
1566
if(mkdtemp(tempdir) == NULL){
1567
tempdir_created = false;
1568
perror("mkdtemp");
1569
goto end;
1570
}
1571
1572
if(quit_now){
1573
goto end;
1574
}
1575
1576
if(not init_gpgme(pubkey, seckey, tempdir)){
1577
fprintf(stderr, "init_gpgme failed\n");
1578
exitcode = EX_UNAVAILABLE;
1579
goto end;
1580
} else {
1581
gpgme_initialized = true;
1582
}
1583
1584
if(quit_now){
1585
goto end;
1586
}
1587
1588
if(connect_to != NULL){
1589
/* Connect directly, do not use Zeroconf */
1590
/* (Mainly meant for debugging) */
1591
char *address = strrchr(connect_to, ':');
1592
if(address == NULL){
1593
fprintf(stderr, "No colon in address\n");
1594
exitcode = EX_USAGE;
1595
goto end;
1596
}
1597
1598
if(quit_now){
1599
goto end;
1600
}
1601
1602
uint16_t port;
1603
errno = 0;
1604
tmpmax = strtoimax(address+1, &tmp, 10);
1605
if(errno != 0 or tmp == address+1 or *tmp != '\0'
1606
or tmpmax != (uint16_t)tmpmax){
1607
fprintf(stderr, "Bad port number\n");
1608
exitcode = EX_USAGE;
1609
goto end;
1610
}
1611
1612
if(quit_now){
1613
goto end;
1614
}
1615
1616
port = (uint16_t)tmpmax;
1617
*address = '\0';
1618
address = connect_to;
1619
/* Colon in address indicates IPv6 */
1620
int af;
1621
if(strchr(address, ':') != NULL){
1622
af = AF_INET6;
1623
} else {
1624
af = AF_INET;
1625
}
1626
1627
if(quit_now){
1628
goto end;
1629
}
1630
1631
while(not quit_now){
1632
ret = start_mandos_communication(address, port, if_index, af);
1633
if(quit_now or ret == 0){
1634
break;
1635
}
1636
sleep(15);
1637
};
1638
1639
if (not quit_now){
1640
exitcode = EXIT_SUCCESS;
1641
}
1642
1643
goto end;
1644
}
1645
1646
if(quit_now){
1647
goto end;
1648
}
1649
1650
{
1651
AvahiServerConfig config;
1652
/* Do not publish any local Zeroconf records */
1653
avahi_server_config_init(&config);
1654
config.publish_hinfo = 0;
1655
config.publish_addresses = 0;
1656
config.publish_workstation = 0;
1657
config.publish_domain = 0;
1658
1659
/* Allocate a new server */
1660
mc.server = avahi_server_new(avahi_simple_poll_get
1661
(mc.simple_poll), &config, NULL,
1662
NULL, &error);
1663
1664
/* Free the Avahi configuration data */
1665
avahi_server_config_free(&config);
1666
}
1667
1668
/* Check if creating the Avahi server object succeeded */
1669
if(mc.server == NULL){
1670
fprintf(stderr, "Failed to create Avahi server: %s\n",
1671
avahi_strerror(error));
1672
exitcode = EX_UNAVAILABLE;
1673
goto end;
1674
}
1675
1676
if(quit_now){
1677
goto end;
1678
}
1679
1680
/* Create the Avahi service browser */
1681
sb = avahi_s_service_browser_new(mc.server, if_index,
1682
AVAHI_PROTO_UNSPEC, "_mandos._tcp",
1683
NULL, 0, browse_callback, NULL);
1684
if(sb == NULL){
1685
fprintf(stderr, "Failed to create service browser: %s\n",
1686
avahi_strerror(avahi_server_errno(mc.server)));
1687
exitcode = EX_UNAVAILABLE;
1688
goto end;
1689
}
1690
1691
if(quit_now){
1692
goto end;
1693
}
1694
1695
/* Run the main loop */
1696
1697
if(debug){
1698
fprintf(stderr, "Starting Avahi loop search\n");
1699
}
1700
1701
avahi_simple_poll_loop(mc.simple_poll);
1702
988
exit(EXIT_FAILURE);
989
}
990
991
if(connect_to != NULL){
992
/* Connect directly, do not use Zeroconf */
993
/* (Mainly meant for debugging) */
994
char *address = strrchr(connect_to, ':');
995
if(address == NULL){
996
fprintf(stderr, "No colon in address\n");
997
exitcode = EXIT_FAILURE;
998
goto end;
999
}
1000
errno = 0;
1001
uint16_t port = (uint16_t) strtol(address+1, NULL, 10);
1002
if(errno){
1003
perror("Bad port number");
1004
exitcode = EXIT_FAILURE;
1005
goto end;
1006
}
1007
*address = '\0';
1008
address = connect_to;
1009
ret = start_mandos_communication(address, port, if_index, &mc);
1010
if(ret < 0){
1011
exitcode = EXIT_FAILURE;
1012
} else {
1013
exitcode = EXIT_SUCCESS;
1014
}
1015
goto end;
1016
}
1017
1018
if (not debug){
1019
avahi_set_log_function(empty_log);
1020
}
1021
1022
/* Initialize the pseudo-RNG for Avahi */
1023
srand((unsigned int) time(NULL));
1024
1025
/* Allocate main Avahi loop object */
1026
mc.simple_poll = avahi_simple_poll_new();
1027
if (mc.simple_poll == NULL) {
1028
fprintf(stderr, "Avahi: Failed to create simple poll"
1029
" object.\n");
1030
exitcode = EXIT_FAILURE;
1031
goto end;
1032
}
1033
1034
{
1035
AvahiServerConfig config;
1036
/* Do not publish any local Zeroconf records */
1037
avahi_server_config_init(&config);
1038
config.publish_hinfo = 0;
1039
config.publish_addresses = 0;
1040
config.publish_workstation = 0;
1041
config.publish_domain = 0;
1042
1043
/* Allocate a new server */
1044
mc.server = avahi_server_new(avahi_simple_poll_get
1045
(mc.simple_poll), &config, NULL,
1046
NULL, &error);
1047
1048
/* Free the Avahi configuration data */
1049
avahi_server_config_free(&config);
1050
}
1051
1052
/* Check if creating the Avahi server object succeeded */
1053
if (mc.server == NULL) {
1054
fprintf(stderr, "Failed to create Avahi server: %s\n",
1055
avahi_strerror(error));
1056
exitcode = EXIT_FAILURE;
1057
goto end;
1058
}
1059
1060
/* Create the Avahi service browser */
1061
sb = avahi_s_service_browser_new(mc.server, if_index,
1062
AVAHI_PROTO_INET6,
1063
"_mandos._tcp", NULL, 0,
1064
browse_callback, &mc);
1065
if (sb == NULL) {
1066
fprintf(stderr, "Failed to create service browser: %s\n",
1067
avahi_strerror(avahi_server_errno(mc.server)));
1068
exitcode = EXIT_FAILURE;
1069
goto end;
1070
}
1071
1072
/* Run the main loop */
1073
1074
if (debug){
1075
fprintf(stderr, "Starting Avahi loop search\n");
1076
}
1077
1078
avahi_simple_poll_loop(mc.simple_poll);
1079
1703
1080
end:
1704
1705
if(debug){
1706
fprintf(stderr, "%s exiting\n", argv[0]);
1707
}
1708
1709
/* Cleanup things */
1710
if(sb != NULL)
1711
avahi_s_service_browser_free(sb);
1712
1713
if(mc.server != NULL)
1714
avahi_server_free(mc.server);
1715
1716
if(mc.simple_poll != NULL)
1717
avahi_simple_poll_free(mc.simple_poll);
1718
1719
if(gnutls_initialized){
1720
gnutls_certificate_free_credentials(mc.cred);
1721
gnutls_global_deinit();
1722
gnutls_dh_params_deinit(mc.dh_params);
1723
}
1724
1725
if(gpgme_initialized){
1726
gpgme_release(mc.ctx);
1727
}
1728
1729
/* Take down the network interface */
1730
if(take_down_interface){
1731
/* Re-raise priviliges */
1732
errno = 0;
1733
ret = seteuid(0);
1734
if(ret == -1){
1735
perror("seteuid");
1736
}
1737
if(geteuid() == 0){
1738
ret = ioctl(sd, SIOCGIFFLAGS, &network);
1739
if(ret == -1){
1740
perror("ioctl SIOCGIFFLAGS");
1741
} else if(network.ifr_flags & IFF_UP) {
1742
network.ifr_flags &= ~(short)IFF_UP; /* clear flag */
1743
ret = ioctl(sd, SIOCSIFFLAGS, &network);
1744
if(ret == -1){
1745
perror("ioctl SIOCSIFFLAGS -IFF_UP");
1746
}
1747
}
1748
ret = (int)TEMP_FAILURE_RETRY(close(sd));
1749
if(ret == -1){
1750
perror("close");
1751
}
1752
/* Lower privileges permanently */
1753
errno = 0;
1754
ret = setuid(uid);
1755
if(ret == -1){
1756
perror("setuid");
1757
}
1758
}
1759
}
1760
1761
/* Removes the temp directory used by GPGME */
1762
if(tempdir_created){
1763
DIR *d;
1764
struct dirent *direntry;
1765
d = opendir(tempdir);
1766
if(d == NULL){
1767
if(errno != ENOENT){
1081
1082
if (debug){
1083
fprintf(stderr, "%s exiting\n", argv[0]);
1084
}
1085
1086
/* Cleanup things */
1087
if (sb != NULL)
1088
avahi_s_service_browser_free(sb);
1089
1090
if (mc.server != NULL)
1091
avahi_server_free(mc.server);
1092
1093
if (mc.simple_poll != NULL)
1094
avahi_simple_poll_free(mc.simple_poll);
1095
1096
if (gnutls_initalized){
1097
gnutls_certificate_free_credentials(mc.cred);
1098
gnutls_global_deinit ();
1099
gnutls_dh_params_deinit(mc.dh_params);
1100
}
1101
1102
if(gpgme_initalized){
1103
gpgme_release(mc.ctx);
1104
}
1105
1106
/* Removes the temp directory used by GPGME */
1107
if(tempdir[0] != '\0'){
1108
DIR *d;
1109
struct dirent *direntry;
1110
d = opendir(tempdir);
1111
if(d == NULL){
1768
1112
perror("opendir");
1769
}
1770
} else {
1771
while(true){
1772
direntry = readdir(d);
1773
if(direntry == NULL){
1774
break;
1775
}
1776
/* Skip "." and ".." */
1777
if(direntry->d_name[0] == '.'
1778
and (direntry->d_name[1] == '\0'
1779
or (direntry->d_name[1] == '.'
1780
and direntry->d_name[2] == '\0'))){
1781
continue;
1782
}
1783
char *fullname = NULL;
1784
ret = asprintf(&fullname, "%s/%s", tempdir,
1785
direntry->d_name);
1786
if(ret < 0){
1787
perror("asprintf");
1788
continue;
1789
}
1790
ret = remove(fullname);
1791
if(ret == -1){
1792
fprintf(stderr, "remove(\"%s\"): %s\n", fullname,
1793
strerror(errno));
1794
}
1795
free(fullname);
1796
}
1797
closedir(d);
1798
}
1799
ret = rmdir(tempdir);
1800
if(ret == -1 and errno != ENOENT){
1801
perror("rmdir");
1802
}
1803
}
1804
1805
if(quit_now){
1806
sigemptyset(&old_sigterm_action.sa_mask);
1807
old_sigterm_action.sa_handler = SIG_DFL;
1808
ret = (int)TEMP_FAILURE_RETRY(sigaction(signal_received,
1809
&old_sigterm_action,
1810
NULL));
1811
if(ret == -1){
1812
perror("sigaction");
1813
}
1814
do {
1815
ret = raise(signal_received);
1816
} while(ret != 0 and errno == EINTR);
1817
if(ret != 0){
1818
perror("raise");
1819
abort();
1820
}
1821
TEMP_FAILURE_RETRY(pause());
1822
}
1823
1824
return exitcode;
1113
} else {
1114
while(true){
1115
direntry = readdir(d);
1116
if(direntry == NULL){
1117
break;
1118
}
1119
if (direntry->d_type == DT_REG){
1120
char *fullname = NULL;
1121
ret = asprintf(&fullname, "%s/%s", tempdir,
1122
direntry->d_name);
1123
if(ret < 0){
1124
perror("asprintf");
1125
continue;
1126
}
1127
ret = unlink(fullname);
1128
if(ret == -1){
1129
fprintf(stderr, "unlink(\"%s\"): %s",
1130
fullname, strerror(errno));
1131
}
1132
free(fullname);
1133
}
1134
}
1135
closedir(d);
1136
}
1137
ret = rmdir(tempdir);
1138
if(ret == -1){
1139
perror("rmdir");
1140
}
1141
}
1142
1143
return exitcode;
1825
1144
}
Loggerhead is a web-based interface for Breezy
Version: 2.0.2.dev0