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/mandosclient.c
- browse files at revision 39
- compare with another revision
- download diff
- download tarball
- view history from revision 39
- Committer: Teddy Hogeborn
- Date: 2008-08-03 03:33:56 UTC
- Revision ID: teddy@fukt.bsnet.se-20080803033356-6aemgj0g0hoz91ow
* plugins.d/mandosclient.c (pgp_packet_decrypt): Renamed variables.
On debug, show
decrypted plaintext
in hexadecimal. Free
the GPGME data
buffers even on
errors.
On debug, show
decrypted plaintext
in hexadecimal. Free
the GPGME data
buffers even on
errors.
- files added:
- ca.pem
- files removed:
- .bzr-builddeb
- debian
- debian/po
- files renamed:
- plugin-runner.c => plugbasedclient.c
- plugins.d/mandos-client.c => plugins.d/mandosclient.c
- plugins.d/password-prompt.c => plugins.d/passprompt.c
- mandos.conf => server.conf
- mandos => server.py
- files modified:
- Makefile
added
removed
plugins.d/mandosclient.c
9
9
* "browse_callback", and parts of "main".
10
10
*
11
11
* Everything else is
12
* Copyright © 2008,2009 Teddy Hogeborn
13
* Copyright © 2008,2009 Björn Påhlsson
12
* Copyright © 2007-2008 Teddy Hogeborn & Björn Påhlsson
14
13
*
15
14
* This program is free software: you can redistribute it and/or
16
15
* modify it under the terms of the GNU General Public License as
33
32
#define _LARGEFILE_SOURCE
34
33
#define _FILE_OFFSET_BITS 64
35
34
36
#define _GNU_SOURCE /* TEMP_FAILURE_RETRY(), asprintf() */
37
38
#include <stdio.h> /* fprintf(), stderr, fwrite(),
39
stdout, ferror() */
40
#include <stdint.h> /* uint16_t, uint32_t */
41
#include <stddef.h> /* NULL, size_t, ssize_t */
42
#include <stdlib.h> /* free(), EXIT_SUCCESS, EXIT_FAILURE,
43
srand() */
44
#include <stdbool.h> /* bool, true */
45
#include <string.h> /* memset(), strcmp(), strlen(),
46
strerror(), asprintf(), strcpy() */
47
#include <sys/ioctl.h> /* ioctl */
48
#include <sys/types.h> /* socket(), inet_pton(), sockaddr,
49
sockaddr_in6, PF_INET6,
50
SOCK_STREAM, INET6_ADDRSTRLEN,
51
uid_t, gid_t, open(), opendir(), DIR */
52
#include <sys/stat.h> /* open() */
53
#include <sys/socket.h> /* socket(), struct sockaddr_in6,
54
struct in6_addr, inet_pton(),
55
connect() */
56
#include <fcntl.h> /* open() */
57
#include <dirent.h> /* opendir(), struct dirent, readdir() */
58
#include <inttypes.h> /* PRIu16 */
59
#include <assert.h> /* assert() */
60
#include <errno.h> /* perror(), errno */
61
#include <time.h> /* time() */
35
#include <stdio.h>
36
#include <assert.h>
37
#include <stdlib.h>
38
#include <time.h>
39
#include <net/if.h> /* if_nametoindex */
40
#include <sys/ioctl.h> /* ioctl, ifreq, SIOCGIFFLAGS, IFF_UP,
41
SIOCSIFFLAGS */
62
42
#include <net/if.h> /* ioctl, ifreq, SIOCGIFFLAGS, IFF_UP,
63
SIOCSIFFLAGS, if_indextoname(),
64
if_nametoindex(), IF_NAMESIZE */
65
#include <netinet/in.h>
66
#include <unistd.h> /* close(), SEEK_SET, off_t, write(),
67
getuid(), getgid(), setuid(),
68
setgid() */
69
#include <arpa/inet.h> /* inet_pton(), htons */
70
#include <iso646.h> /* not, and */
71
#include <argp.h> /* struct argp_option, error_t, struct
72
argp_state, struct argp,
73
argp_parse(), ARGP_KEY_ARG,
74
ARGP_KEY_END, ARGP_ERR_UNKNOWN */
43
SIOCSIFFLAGS */
75
44
76
/* Avahi */
77
/* All Avahi types, constants and functions
78
Avahi*, avahi_*,
79
AVAHI_* */
80
45
#include <avahi-core/core.h>
81
46
#include <avahi-core/lookup.h>
82
47
#include <avahi-core/log.h>
84
49
#include <avahi-common/malloc.h>
85
50
#include <avahi-common/error.h>
86
51
87
/* GnuTLS */
88
#include <gnutls/gnutls.h> /* All GnuTLS types, constants and
89
functions:
90
gnutls_*
91
init_gnutls_session(),
92
GNUTLS_* */
93
#include <gnutls/openpgp.h> /* gnutls_certificate_set_openpgp_key_file(),
94
GNUTLS_OPENPGP_FMT_BASE64 */
95
96
/* GPGME */
97
#include <gpgme.h> /* All GPGME types, constants and
98
functions:
99
gpgme_*
100
GPGME_PROTOCOL_OpenPGP,
101
GPG_ERR_NO_* */
52
//mandos client part
53
#include <sys/types.h> /* socket(), inet_pton() */
54
#include <sys/socket.h> /* socket(), struct sockaddr_in6,
55
struct in6_addr, inet_pton() */
56
#include <gnutls/gnutls.h> /* All GnuTLS stuff */
57
#include <gnutls/openpgp.h> /* GnuTLS with openpgp stuff */
58
59
#include <unistd.h> /* close() */
60
#include <netinet/in.h>
61
#include <stdbool.h> /* true */
62
#include <string.h> /* memset */
63
#include <arpa/inet.h> /* inet_pton() */
64
#include <iso646.h> /* not */
65
66
// gpgme
67
#include <errno.h> /* perror() */
68
#include <gpgme.h>
69
70
// getopt_long
71
#include <getopt.h>
102
72
103
73
#define BUFFER_SIZE 256
104
74
105
#define PATHDIR "/conf/conf.d/mandos"
106
#define SECKEY "seckey.txt"
107
#define PUBKEY "pubkey.txt"
75
static const char *keydir = "/conf/conf.d/mandos";
76
static const char *pubkeyfile = "pubkey.txt";
77
static const char *seckeyfile = "seckey.txt";
108
78
109
79
bool debug = false;
110
static const char mandos_protocol_version[] = "1";
111
const char *argp_program_version = "mandos-client " VERSION;
112
const char *argp_program_bug_address = "<mandos@fukt.bsnet.se>";
113
80
114
/* Used for passing in values through the Avahi callback functions */
81
/* Used for passing in values through all the callback functions */
115
82
typedef struct {
116
83
AvahiSimplePoll *simple_poll;
117
84
AvahiServer *server;
118
85
gnutls_certificate_credentials_t cred;
119
86
unsigned int dh_bits;
120
gnutls_dh_params_t dh_params;
121
87
const char *priority;
88
} mandos_context;
89
90
/*
91
* Decrypt OpenPGP data using keyrings in HOMEDIR.
92
* Returns -1 on error
93
*/
94
static ssize_t pgp_packet_decrypt (const char *cryptotext,
95
size_t crypto_size,
96
char **plaintext,
97
const char *homedir){
98
gpgme_data_t dh_crypto, dh_plain;
122
99
gpgme_ctx_t ctx;
123
} mandos_context;
124
125
/*
126
* Make room in "buffer" for at least BUFFER_SIZE additional bytes.
127
* "buffer_capacity" is how much is currently allocated,
128
* "buffer_length" is how much is already used.
129
*/
130
size_t adjustbuffer(char **buffer, size_t buffer_length,
131
size_t buffer_capacity){
132
if (buffer_length + BUFFER_SIZE > buffer_capacity){
133
*buffer = realloc(*buffer, buffer_capacity + BUFFER_SIZE);
134
if (buffer == NULL){
135
return 0;
136
}
137
buffer_capacity += BUFFER_SIZE;
138
}
139
return buffer_capacity;
140
}
141
142
/*
143
* Initialize GPGME.
144
*/
145
static bool init_gpgme(mandos_context *mc, const char *seckey,
146
const char *pubkey, const char *tempdir){
147
int ret;
148
100
gpgme_error_t rc;
101
ssize_t ret;
102
ssize_t plaintext_capacity = 0;
103
ssize_t plaintext_length = 0;
149
104
gpgme_engine_info_t engine_info;
150
105
151
152
/*
153
* Helper function to insert pub and seckey to the enigne keyring.
154
*/
155
bool import_key(const char *filename){
156
int fd;
157
gpgme_data_t pgp_data;
158
159
fd = (int)TEMP_FAILURE_RETRY(open(filename, O_RDONLY));
160
if(fd == -1){
161
perror("open");
162
return false;
163
}
164
165
rc = gpgme_data_new_from_fd(&pgp_data, fd);
166
if (rc != GPG_ERR_NO_ERROR){
167
fprintf(stderr, "bad gpgme_data_new_from_fd: %s: %s\n",
168
gpgme_strsource(rc), gpgme_strerror(rc));
169
return false;
170
}
171
172
rc = gpgme_op_import(mc->ctx, pgp_data);
173
if (rc != GPG_ERR_NO_ERROR){
174
fprintf(stderr, "bad gpgme_op_import: %s: %s\n",
175
gpgme_strsource(rc), gpgme_strerror(rc));
176
return false;
177
}
178
179
ret = (int)TEMP_FAILURE_RETRY(close(fd));
180
if(ret == -1){
181
perror("close");
182
}
183
gpgme_data_release(pgp_data);
184
return true;
185
}
186
187
106
if (debug){
188
fprintf(stderr, "Initialize gpgme\n");
107
fprintf(stderr, "Trying to decrypt OpenPGP data\n");
189
108
}
190
109
191
110
/* Init GPGME */
194
113
if (rc != GPG_ERR_NO_ERROR){
195
114
fprintf(stderr, "bad gpgme_engine_check_version: %s: %s\n",
196
115
gpgme_strsource(rc), gpgme_strerror(rc));
197
return false;
116
return -1;
198
117
}
199
118
200
/* Set GPGME home directory for the OpenPGP engine only */
119
/* Set GPGME home directory for the OpenPGP engine only */
201
120
rc = gpgme_get_engine_info (&engine_info);
202
121
if (rc != GPG_ERR_NO_ERROR){
203
122
fprintf(stderr, "bad gpgme_get_engine_info: %s: %s\n",
204
123
gpgme_strsource(rc), gpgme_strerror(rc));
205
return false;
124
return -1;
206
125
}
207
126
while(engine_info != NULL){
208
127
if(engine_info->protocol == GPGME_PROTOCOL_OpenPGP){
209
128
gpgme_set_engine_info(GPGME_PROTOCOL_OpenPGP,
210
engine_info->file_name, tempdir);
129
engine_info->file_name, homedir);
211
130
break;
212
131
}
213
132
engine_info = engine_info->next;
214
133
}
215
134
if(engine_info == NULL){
216
fprintf(stderr, "Could not set GPGME home dir to %s\n", tempdir);
217
return false;
218
}
219
220
/* Create new GPGME "context" */
221
rc = gpgme_new(&(mc->ctx));
222
if (rc != GPG_ERR_NO_ERROR){
223
fprintf(stderr, "bad gpgme_new: %s: %s\n",
224
gpgme_strsource(rc), gpgme_strerror(rc));
225
return false;
226
}
227
228
if (not import_key(pubkey) or not import_key(seckey)){
229
return false;
230
}
231
232
return true;
233
}
234
235
/*
236
* Decrypt OpenPGP data.
237
* Returns -1 on error
238
*/
239
static ssize_t pgp_packet_decrypt (const mandos_context *mc,
240
const char *cryptotext,
241
size_t crypto_size,
242
char **plaintext){
243
gpgme_data_t dh_crypto, dh_plain;
244
gpgme_error_t rc;
245
ssize_t ret;
246
size_t plaintext_capacity = 0;
247
ssize_t plaintext_length = 0;
248
249
if (debug){
250
fprintf(stderr, "Trying to decrypt OpenPGP data\n");
135
fprintf(stderr, "Could not set GPGME home dir to %s\n", homedir);
136
return -1;
251
137
}
252
138
253
139
/* Create new GPGME data buffer from memory cryptotext */
268
154
return -1;
269
155
}
270
156
157
/* Create new GPGME "context" */
158
rc = gpgme_new(&ctx);
159
if (rc != GPG_ERR_NO_ERROR){
160
fprintf(stderr, "bad gpgme_new: %s: %s\n",
161
gpgme_strsource(rc), gpgme_strerror(rc));
162
plaintext_length = -1;
163
goto decrypt_end;
164
}
165
271
166
/* Decrypt data from the cryptotext data buffer to the plaintext
272
167
data buffer */
273
rc = gpgme_op_decrypt(mc->ctx, dh_crypto, dh_plain);
168
rc = gpgme_op_decrypt(ctx, dh_crypto, dh_plain);
274
169
if (rc != GPG_ERR_NO_ERROR){
275
170
fprintf(stderr, "bad gpgme_op_decrypt: %s: %s\n",
276
171
gpgme_strsource(rc), gpgme_strerror(rc));
277
172
plaintext_length = -1;
278
if (debug){
279
gpgme_decrypt_result_t result;
280
result = gpgme_op_decrypt_result(mc->ctx);
281
if (result == NULL){
282
fprintf(stderr, "gpgme_op_decrypt_result failed\n");
283
} else {
284
fprintf(stderr, "Unsupported algorithm: %s\n",
285
result->unsupported_algorithm);
286
fprintf(stderr, "Wrong key usage: %u\n",
287
result->wrong_key_usage);
288
if(result->file_name != NULL){
289
fprintf(stderr, "File name: %s\n", result->file_name);
290
}
291
gpgme_recipient_t recipient;
292
recipient = result->recipients;
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
}
303
}
304
}
305
}
306
173
goto decrypt_end;
307
174
}
308
175
310
177
fprintf(stderr, "Decryption of OpenPGP data succeeded\n");
311
178
}
312
179
180
if (debug){
181
gpgme_decrypt_result_t result;
182
result = gpgme_op_decrypt_result(ctx);
183
if (result == NULL){
184
fprintf(stderr, "gpgme_op_decrypt_result failed\n");
185
} else {
186
fprintf(stderr, "Unsupported algorithm: %s\n",
187
result->unsupported_algorithm);
188
fprintf(stderr, "Wrong key usage: %d\n",
189
result->wrong_key_usage);
190
if(result->file_name != NULL){
191
fprintf(stderr, "File name: %s\n", result->file_name);
192
}
193
gpgme_recipient_t recipient;
194
recipient = result->recipients;
195
if(recipient){
196
while(recipient != NULL){
197
fprintf(stderr, "Public key algorithm: %s\n",
198
gpgme_pubkey_algo_name(recipient->pubkey_algo));
199
fprintf(stderr, "Key ID: %s\n", recipient->keyid);
200
fprintf(stderr, "Secret key available: %s\n",
201
recipient->status == GPG_ERR_NO_SECKEY
202
? "No" : "Yes");
203
recipient = recipient->next;
204
}
205
}
206
}
207
}
208
313
209
/* Seek back to the beginning of the GPGME plaintext data buffer */
314
210
if (gpgme_data_seek(dh_plain, (off_t) 0, SEEK_SET) == -1){
315
perror("gpgme_data_seek");
211
perror("pgpme_data_seek");
316
212
plaintext_length = -1;
317
213
goto decrypt_end;
318
214
}
319
215
320
216
*plaintext = NULL;
321
217
while(true){
322
plaintext_capacity = adjustbuffer(plaintext,
323
(size_t)plaintext_length,
324
plaintext_capacity);
325
if (plaintext_capacity == 0){
326
perror("adjustbuffer");
218
if (plaintext_length + BUFFER_SIZE > plaintext_capacity){
219
*plaintext = realloc(*plaintext,
220
(unsigned int)plaintext_capacity
221
+ BUFFER_SIZE);
222
if (*plaintext == NULL){
223
perror("realloc");
327
224
plaintext_length = -1;
328
225
goto decrypt_end;
226
}
227
plaintext_capacity += BUFFER_SIZE;
329
228
}
330
229
331
230
ret = gpgme_data_read(dh_plain, *plaintext + plaintext_length,
342
241
}
343
242
plaintext_length += ret;
344
243
}
345
244
346
245
if(debug){
347
246
fprintf(stderr, "Decrypted password is: ");
348
for(ssize_t i = 0; i < plaintext_length; i++){
247
for(size_t i = 0; i < plaintext_length; i++){
349
248
fprintf(stderr, "%02hhX ", (*plaintext)[i]);
350
249
}
351
250
fprintf(stderr, "\n");
362
261
}
363
262
364
263
static const char * safer_gnutls_strerror (int value) {
365
const char *ret = gnutls_strerror (value); /* Spurious warning */
264
const char *ret = gnutls_strerror (value);
366
265
if (ret == NULL)
367
266
ret = "(unknown)";
368
267
return ret;
369
268
}
370
269
371
/* GnuTLS log function callback */
372
270
static void debuggnutls(__attribute__((unused)) int level,
373
271
const char* string){
374
fprintf(stderr, "GnuTLS: %s", string);
272
fprintf(stderr, "%s", string);
375
273
}
376
274
377
static int init_gnutls_global(mandos_context *mc,
378
const char *pubkeyfilename,
379
const char *seckeyfilename){
275
static int initgnutls(mandos_context *mc, gnutls_session_t *session,
276
gnutls_dh_params_t *dh_params){
277
const char *err;
380
278
int ret;
381
279
382
280
if(debug){
383
281
fprintf(stderr, "Initializing GnuTLS\n");
384
282
}
385
386
ret = gnutls_global_init();
387
if (ret != GNUTLS_E_SUCCESS) {
388
fprintf (stderr, "GnuTLS global_init: %s\n",
389
safer_gnutls_strerror(ret));
283
284
if ((ret = gnutls_global_init ())
285
!= GNUTLS_E_SUCCESS) {
286
fprintf (stderr, "global_init: %s\n", safer_gnutls_strerror(ret));
390
287
return -1;
391
288
}
392
289
393
290
if (debug){
394
/* "Use a log level over 10 to enable all debugging options."
395
* - GnuTLS manual
396
*/
397
291
gnutls_global_set_log_level(11);
398
292
gnutls_global_set_log_function(debuggnutls);
399
293
}
400
294
401
/* OpenPGP credentials */
402
gnutls_certificate_allocate_credentials(&mc->cred);
403
if (ret != GNUTLS_E_SUCCESS){
404
fprintf (stderr, "GnuTLS memory error: %s\n", /* Spurious
405
warning */
295
/* openpgp credentials */
296
if ((ret = gnutls_certificate_allocate_credentials (&mc->cred))
297
!= GNUTLS_E_SUCCESS) {
298
fprintf (stderr, "memory error: %s\n",
406
299
safer_gnutls_strerror(ret));
407
gnutls_global_deinit ();
408
300
return -1;
409
301
}
410
302
411
303
if(debug){
412
fprintf(stderr, "Attempting to use OpenPGP public key %s and"
413
" secret key %s as GnuTLS credentials\n", pubkeyfilename,
414
seckeyfilename);
304
fprintf(stderr, "Attempting to use OpenPGP certificate %s"
305
" and keyfile %s as GnuTLS credentials\n", pubkeyfile,
306
seckeyfile);
415
307
}
416
308
417
309
ret = gnutls_certificate_set_openpgp_key_file
418
(mc->cred, pubkeyfilename, seckeyfilename,
419
GNUTLS_OPENPGP_FMT_BASE64);
310
(mc->cred, pubkeyfile, seckeyfile, GNUTLS_OPENPGP_FMT_BASE64);
420
311
if (ret != GNUTLS_E_SUCCESS) {
421
fprintf(stderr,
422
"Error[%d] while reading the OpenPGP key pair ('%s',"
423
" '%s')\n", ret, pubkeyfilename, seckeyfilename);
424
fprintf(stderr, "The GnuTLS error is: %s\n",
312
fprintf
313
(stderr, "Error[%d] while reading the OpenPGP key pair ('%s',"
314
" '%s')\n",
315
ret, pubkeyfile, seckeyfile);
316
fprintf(stdout, "The Error is: %s\n",
425
317
safer_gnutls_strerror(ret));
426
goto globalfail;
427
}
428
429
/* GnuTLS server initialization */
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));
434
goto globalfail;
435
}
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));
440
goto globalfail;
441
}
442
443
gnutls_certificate_set_dh_params(mc->cred, mc->dh_params);
444
445
return 0;
446
447
globalfail:
448
449
gnutls_certificate_free_credentials(mc->cred);
450
gnutls_global_deinit();
451
gnutls_dh_params_deinit(mc->dh_params);
452
return -1;
453
}
454
455
static int init_gnutls_session(mandos_context *mc,
456
gnutls_session_t *session){
457
int ret;
458
/* GnuTLS session creation */
459
ret = gnutls_init(session, GNUTLS_SERVER);
460
if (ret != GNUTLS_E_SUCCESS){
318
return -1;
319
}
320
321
//GnuTLS server initialization
322
if ((ret = gnutls_dh_params_init(dh_params))
323
!= GNUTLS_E_SUCCESS) {
324
fprintf (stderr, "Error in dh parameter initialization: %s\n",
325
safer_gnutls_strerror(ret));
326
return -1;
327
}
328
329
if ((ret = gnutls_dh_params_generate2(*dh_params, mc->dh_bits))
330
!= GNUTLS_E_SUCCESS) {
331
fprintf (stderr, "Error in prime generation: %s\n",
332
safer_gnutls_strerror(ret));
333
return -1;
334
}
335
336
gnutls_certificate_set_dh_params(mc->cred, *dh_params);
337
338
// GnuTLS session creation
339
if ((ret = gnutls_init(session, GNUTLS_SERVER))
340
!= GNUTLS_E_SUCCESS){
461
341
fprintf(stderr, "Error in GnuTLS session initialization: %s\n",
462
342
safer_gnutls_strerror(ret));
463
343
}
464
344
465
{
466
const char *err;
467
ret = gnutls_priority_set_direct(*session, mc->priority, &err);
468
if (ret != GNUTLS_E_SUCCESS) {
469
fprintf(stderr, "Syntax error at: %s\n", err);
470
fprintf(stderr, "GnuTLS error: %s\n",
471
safer_gnutls_strerror(ret));
472
gnutls_deinit (*session);
473
return -1;
474
}
345
if ((ret = gnutls_priority_set_direct(*session, mc->priority, &err))
346
!= GNUTLS_E_SUCCESS) {
347
fprintf(stderr, "Syntax error at: %s\n", err);
348
fprintf(stderr, "GnuTLS error: %s\n",
349
safer_gnutls_strerror(ret));
350
return -1;
475
351
}
476
352
477
ret = gnutls_credentials_set(*session, GNUTLS_CRD_CERTIFICATE,
478
mc->cred);
479
if (ret != GNUTLS_E_SUCCESS) {
480
fprintf(stderr, "Error setting GnuTLS credentials: %s\n",
353
if ((ret = gnutls_credentials_set(*session, GNUTLS_CRD_CERTIFICATE,
354
mc->cred))
355
!= GNUTLS_E_SUCCESS) {
356
fprintf(stderr, "Error setting a credentials set: %s\n",
481
357
safer_gnutls_strerror(ret));
482
gnutls_deinit (*session);
483
358
return -1;
484
359
}
485
360
492
367
return 0;
493
368
}
494
369
495
/* Avahi log function callback */
496
370
static void empty_log(__attribute__((unused)) AvahiLogLevel level,
497
371
__attribute__((unused)) const char *txt){}
498
372
499
/* Called when a Mandos server is found */
500
373
static int start_mandos_communication(const char *ip, uint16_t port,
501
374
AvahiIfIndex if_index,
502
375
mandos_context *mc){
503
376
int ret, tcp_sd;
504
ssize_t sret;
505
union { struct sockaddr in; struct sockaddr_in6 in6; } to;
377
struct sockaddr_in6 to;
506
378
char *buffer = NULL;
507
379
char *decrypted_buffer;
508
380
size_t buffer_length = 0;
509
381
size_t buffer_capacity = 0;
510
382
ssize_t decrypted_buffer_size;
511
size_t written;
383
size_t written = 0;
512
384
int retval = 0;
513
385
char interface[IF_NAMESIZE];
514
386
gnutls_session_t session;
515
516
ret = init_gnutls_session (mc, &session);
517
if (ret != 0){
518
return -1;
519
}
387
gnutls_dh_params_t dh_params;
520
388
521
389
if(debug){
522
fprintf(stderr, "Setting up a tcp connection to %s, port %" PRIu16
523
"\n", ip, port);
390
fprintf(stderr, "Setting up a tcp connection to %s, port %d\n",
391
ip, port);
524
392
}
525
393
526
394
tcp_sd = socket(PF_INET6, SOCK_STREAM, 0);
528
396
perror("socket");
529
397
return -1;
530
398
}
531
399
532
400
if(debug){
533
401
if(if_indextoname((unsigned int)if_index, interface) == NULL){
534
402
perror("if_indextoname");
537
405
fprintf(stderr, "Binding to interface %s\n", interface);
538
406
}
539
407
540
memset(&to, 0, sizeof(to));
541
to.in6.sin6_family = AF_INET6;
542
/* It would be nice to have a way to detect if we were passed an
543
IPv4 address here. Now we assume an IPv6 address. */
544
ret = inet_pton(AF_INET6, ip, &to.in6.sin6_addr);
408
memset(&to,0,sizeof(to)); /* Spurious warning */
409
to.sin6_family = AF_INET6;
410
ret = inet_pton(AF_INET6, ip, &to.sin6_addr);
545
411
if (ret < 0 ){
546
412
perror("inet_pton");
547
413
return -1;
550
416
fprintf(stderr, "Bad address: %s\n", ip);
551
417
return -1;
552
418
}
553
to.in6.sin6_port = htons(port); /* Spurious warning */
419
to.sin6_port = htons(port); /* Spurious warning */
554
420
555
to.in6.sin6_scope_id = (uint32_t)if_index;
421
to.sin6_scope_id = (uint32_t)if_index;
556
422
557
423
if(debug){
558
fprintf(stderr, "Connection to: %s, port %" PRIu16 "\n", ip,
559
port);
424
fprintf(stderr, "Connection to: %s, port %d\n", ip, port);
560
425
char addrstr[INET6_ADDRSTRLEN] = "";
561
if(inet_ntop(to.in6.sin6_family, &(to.in6.sin6_addr), addrstr,
426
if(inet_ntop(to.sin6_family, &(to.sin6_addr), addrstr,
562
427
sizeof(addrstr)) == NULL){
563
428
perror("inet_ntop");
564
429
} else {
568
433
}
569
434
}
570
435
571
ret = connect(tcp_sd, &to.in, sizeof(to));
436
ret = connect(tcp_sd, (struct sockaddr *) &to, sizeof(to));
572
437
if (ret < 0){
573
438
perror("connect");
574
439
return -1;
575
440
}
576
441
577
const char *out = mandos_protocol_version;
578
written = 0;
579
while (true){
580
size_t out_size = strlen(out);
581
ret = (int)TEMP_FAILURE_RETRY(write(tcp_sd, out + written,
582
out_size - written));
583
if (ret == -1){
584
perror("write");
585
retval = -1;
586
goto mandos_end;
587
}
588
written += (size_t)ret;
589
if(written < out_size){
590
continue;
591
} else {
592
if (out == mandos_protocol_version){
593
written = 0;
594
out = "\r\n";
595
} else {
596
break;
597
}
598
}
442
ret = initgnutls (mc, &session, &dh_params);
443
if (ret != 0){
444
retval = -1;
445
return -1;
599
446
}
600
447
448
gnutls_transport_set_ptr (session, (gnutls_transport_ptr_t) tcp_sd);
449
601
450
if(debug){
602
451
fprintf(stderr, "Establishing TLS session with %s\n", ip);
603
452
}
604
453
605
gnutls_transport_set_ptr (session, (gnutls_transport_ptr_t) tcp_sd);
606
607
do{
608
ret = gnutls_handshake (session);
609
} while(ret == GNUTLS_E_AGAIN or ret == GNUTLS_E_INTERRUPTED);
454
ret = gnutls_handshake (session);
610
455
611
456
if (ret != GNUTLS_E_SUCCESS){
612
457
if(debug){
613
fprintf(stderr, "*** GnuTLS Handshake failed ***\n");
458
fprintf(stderr, "\n*** Handshake failed ***\n");
614
459
gnutls_perror (ret);
615
460
}
616
461
retval = -1;
617
goto mandos_end;
462
goto exit;
618
463
}
619
464
620
/* Read OpenPGP packet that contains the wanted password */
465
//Retrieve OpenPGP packet that contains the wanted password
621
466
622
467
if(debug){
623
468
fprintf(stderr, "Retrieving pgp encrypted password from %s\n",
624
469
ip);
625
470
}
626
471
627
472
while(true){
628
buffer_capacity = adjustbuffer(&buffer, buffer_length,
629
buffer_capacity);
630
if (buffer_capacity == 0){
631
perror("adjustbuffer");
632
retval = -1;
633
goto mandos_end;
473
if (buffer_length + BUFFER_SIZE > buffer_capacity){
474
buffer = realloc(buffer, buffer_capacity + BUFFER_SIZE);
475
if (buffer == NULL){
476
perror("realloc");
477
goto exit;
478
}
479
buffer_capacity += BUFFER_SIZE;
634
480
}
635
481
636
sret = gnutls_record_recv(session, buffer+buffer_length,
637
BUFFER_SIZE);
638
if (sret == 0){
482
ret = gnutls_record_recv(session, buffer+buffer_length,
483
BUFFER_SIZE);
484
if (ret == 0){
639
485
break;
640
486
}
641
if (sret < 0){
642
switch(sret){
487
if (ret < 0){
488
switch(ret){
643
489
case GNUTLS_E_INTERRUPTED:
644
490
case GNUTLS_E_AGAIN:
645
491
break;
646
492
case GNUTLS_E_REHANDSHAKE:
647
do{
648
ret = gnutls_handshake (session);
649
} while(ret == GNUTLS_E_AGAIN or ret == GNUTLS_E_INTERRUPTED);
493
ret = gnutls_handshake (session);
650
494
if (ret < 0){
651
fprintf(stderr, "*** GnuTLS Re-handshake failed ***\n");
495
fprintf(stderr, "\n*** Handshake failed ***\n");
652
496
gnutls_perror (ret);
653
497
retval = -1;
654
goto mandos_end;
498
goto exit;
655
499
}
656
500
break;
657
501
default:
658
502
fprintf(stderr, "Unknown error while reading data from"
659
" encrypted session with Mandos server\n");
503
" encrypted session with mandos server\n");
660
504
retval = -1;
661
505
gnutls_bye (session, GNUTLS_SHUT_RDWR);
662
goto mandos_end;
506
goto exit;
663
507
}
664
508
} else {
665
buffer_length += (size_t) sret;
509
buffer_length += (size_t) ret;
666
510
}
667
511
}
668
512
669
if(debug){
670
fprintf(stderr, "Closing TLS session\n");
671
}
672
673
gnutls_bye (session, GNUTLS_SHUT_RDWR);
674
675
513
if (buffer_length > 0){
676
decrypted_buffer_size = pgp_packet_decrypt(mc, buffer,
514
decrypted_buffer_size = pgp_packet_decrypt(buffer,
677
515
buffer_length,
678
&decrypted_buffer);
516
&decrypted_buffer,
517
keydir);
679
518
if (decrypted_buffer_size >= 0){
680
written = 0;
681
519
while(written < (size_t) decrypted_buffer_size){
682
520
ret = (int)fwrite (decrypted_buffer + written, 1,
683
521
(size_t)decrypted_buffer_size - written,
696
534
} else {
697
535
retval = -1;
698
536
}
699
} else {
700
retval = -1;
701
}
702
703
/* Shutdown procedure */
704
705
mandos_end:
537
}
538
539
//shutdown procedure
540
541
if(debug){
542
fprintf(stderr, "Closing TLS session\n");
543
}
544
706
545
free(buffer);
707
ret = (int)TEMP_FAILURE_RETRY(close(tcp_sd));
708
if(ret == -1){
709
perror("close");
710
}
546
gnutls_bye (session, GNUTLS_SHUT_RDWR);
547
exit:
548
close(tcp_sd);
711
549
gnutls_deinit (session);
550
gnutls_certificate_free_credentials (mc->cred);
551
gnutls_global_deinit ();
712
552
return retval;
713
553
}
714
554
727
567
flags,
728
568
void* userdata) {
729
569
mandos_context *mc = userdata;
730
assert(r);
570
assert(r); /* Spurious warning */
731
571
732
572
/* Called whenever a service has been resolved successfully or
733
573
timed out */
735
575
switch (event) {
736
576
default:
737
577
case AVAHI_RESOLVER_FAILURE:
738
fprintf(stderr, "(Avahi Resolver) Failed to resolve service '%s'"
739
" of type '%s' in domain '%s': %s\n", name, type, domain,
578
fprintf(stderr, "(Resolver) Failed to resolve service '%s' of"
579
" type '%s' in domain '%s': %s\n", name, type, domain,
740
580
avahi_strerror(avahi_server_errno(mc->server)));
741
581
break;
742
582
745
585
char ip[AVAHI_ADDRESS_STR_MAX];
746
586
avahi_address_snprint(ip, sizeof(ip), address);
747
587
if(debug){
748
fprintf(stderr, "Mandos server \"%s\" found on %s (%s, %"
749
PRIu16 ") on port %d\n", name, host_name, ip,
750
interface, port);
588
fprintf(stderr, "Mandos server \"%s\" found on %s (%s) on"
589
" port %d\n", name, host_name, ip, port);
751
590
}
752
591
int ret = start_mandos_communication(ip, port, interface, mc);
753
592
if (ret == 0){
754
avahi_simple_poll_quit(mc->simple_poll);
593
exit(EXIT_SUCCESS);
755
594
}
756
595
}
757
596
}
769
608
flags,
770
609
void* userdata) {
771
610
mandos_context *mc = userdata;
772
assert(b);
611
assert(b); /* Spurious warning */
773
612
774
613
/* Called whenever a new services becomes available on the LAN or
775
614
is removed from the LAN */
778
617
default:
779
618
case AVAHI_BROWSER_FAILURE:
780
619
781
fprintf(stderr, "(Avahi browser) %s\n",
620
fprintf(stderr, "(Browser) %s\n",
782
621
avahi_strerror(avahi_server_errno(mc->server)));
783
622
avahi_simple_poll_quit(mc->simple_poll);
784
623
return;
785
624
786
625
case AVAHI_BROWSER_NEW:
787
/* We ignore the returned Avahi resolver object. In the callback
788
function we free it. If the Avahi server is terminated before
789
the callback function is called the Avahi server will free the
790
resolver for us. */
626
/* We ignore the returned resolver object. In the callback
627
function we free it. If the server is terminated before
628
the callback function is called the server will free
629
the resolver for us. */
791
630
792
631
if (!(avahi_s_service_resolver_new(mc->server, interface,
793
632
protocol, name, type, domain,
794
633
AVAHI_PROTO_INET6, 0,
795
634
resolve_callback, mc)))
796
fprintf(stderr, "Avahi: Failed to resolve service '%s': %s\n",
797
name, avahi_strerror(avahi_server_errno(mc->server)));
635
fprintf(stderr, "Failed to resolve service '%s': %s\n", name,
636
avahi_strerror(avahi_server_errno(mc->server)));
798
637
break;
799
638
800
639
case AVAHI_BROWSER_REMOVE:
802
641
803
642
case AVAHI_BROWSER_ALL_FOR_NOW:
804
643
case AVAHI_BROWSER_CACHE_EXHAUSTED:
805
if(debug){
806
fprintf(stderr, "No Mandos server found, still searching...\n");
807
}
808
644
break;
809
645
}
810
646
}
811
647
812
int main(int argc, char *argv[]){
648
/* Combines file name and path and returns the malloced new
649
string. some sane checks could/should be added */
650
static const char *combinepath(const char *first, const char *second){
651
size_t f_len = strlen(first);
652
size_t s_len = strlen(second);
653
char *tmp = malloc(f_len + s_len + 2);
654
if (tmp == NULL){
655
return NULL;
656
}
657
if(f_len > 0){
658
memcpy(tmp, first, f_len); /* Spurious warning */
659
}
660
tmp[f_len] = '/';
661
if(s_len > 0){
662
memcpy(tmp + f_len + 1, second, s_len); /* Spurious warning */
663
}
664
tmp[f_len + 1 + s_len] = '\0';
665
return tmp;
666
}
667
668
669
int main(AVAHI_GCC_UNUSED int argc, AVAHI_GCC_UNUSED char*argv[]) {
670
AvahiServerConfig config;
813
671
AvahiSServiceBrowser *sb = NULL;
814
672
int error;
815
673
int ret;
816
int exitcode = EXIT_SUCCESS;
674
int debug_int;
675
int returncode = EXIT_SUCCESS;
817
676
const char *interface = "eth0";
818
677
struct ifreq network;
819
678
int sd;
820
uid_t uid;
821
gid_t gid;
822
679
char *connect_to = NULL;
823
char tempdir[] = "/tmp/mandosXXXXXX";
824
680
AvahiIfIndex if_index = AVAHI_IF_UNSPEC;
825
const char *seckey = PATHDIR "/" SECKEY;
826
const char *pubkey = PATHDIR "/" PUBKEY;
827
828
681
mandos_context mc = { .simple_poll = NULL, .server = NULL,
829
.dh_bits = 1024, .priority = "SECURE256"
830
":!CTYPE-X.509:+CTYPE-OPENPGP" };
831
bool gnutls_initalized = false;
832
bool gpgme_initalized = false;
833
834
{
835
struct argp_option options[] = {
836
{ .name = "debug", .key = 128,
837
.doc = "Debug mode", .group = 3 },
838
{ .name = "connect", .key = 'c',
839
.arg = "ADDRESS:PORT",
840
.doc = "Connect directly to a specific Mandos server",
841
.group = 1 },
842
{ .name = "interface", .key = 'i',
843
.arg = "NAME",
844
.doc = "Interface that will be used to search for Mandos"
845
" servers",
846
.group = 1 },
847
{ .name = "seckey", .key = 's',
848
.arg = "FILE",
849
.doc = "OpenPGP secret key file base name",
850
.group = 1 },
851
{ .name = "pubkey", .key = 'p',
852
.arg = "FILE",
853
.doc = "OpenPGP public key file base name",
854
.group = 2 },
855
{ .name = "dh-bits", .key = 129,
856
.arg = "BITS",
857
.doc = "Bit length of the prime number used in the"
858
" Diffie-Hellman key exchange",
859
.group = 2 },
860
{ .name = "priority", .key = 130,
861
.arg = "STRING",
862
.doc = "GnuTLS priority string for the TLS handshake",
863
.group = 1 },
864
{ .name = NULL }
865
};
866
867
error_t parse_opt (int key, char *arg,
868
struct argp_state *state) {
869
/* Get the INPUT argument from `argp_parse', which we know is
870
a pointer to our plugin list pointer. */
871
switch (key) {
872
case 128: /* --debug */
873
debug = true;
874
break;
875
case 'c': /* --connect */
876
connect_to = arg;
877
break;
878
case 'i': /* --interface */
879
interface = arg;
880
break;
881
case 's': /* --seckey */
882
seckey = arg;
883
break;
884
case 'p': /* --pubkey */
885
pubkey = arg;
886
break;
887
case 129: /* --dh-bits */
888
errno = 0;
889
mc.dh_bits = (unsigned int) strtol(arg, NULL, 10);
890
if (errno){
891
perror("strtol");
892
exit(EXIT_FAILURE);
893
}
894
break;
895
case 130: /* --priority */
896
mc.priority = arg;
897
break;
898
case ARGP_KEY_ARG:
899
argp_usage (state);
900
case ARGP_KEY_END:
901
break;
902
default:
903
return ARGP_ERR_UNKNOWN;
904
}
905
return 0;
906
}
907
908
struct argp argp = { .options = options, .parser = parse_opt,
909
.args_doc = "",
910
.doc = "Mandos client -- Get and decrypt"
911
" passwords from a Mandos server" };
912
ret = argp_parse (&argp, argc, argv, 0, 0, NULL);
913
if (ret == ARGP_ERR_UNKNOWN){
914
fprintf(stderr, "Unknown error while parsing arguments\n");
915
exitcode = EXIT_FAILURE;
916
goto end;
917
}
918
}
919
920
/* If the interface is down, bring it up */
921
{
922
sd = socket(PF_INET6, SOCK_DGRAM, IPPROTO_IP);
923
if(sd < 0) {
924
perror("socket");
925
exitcode = EXIT_FAILURE;
926
goto end;
927
}
928
strcpy(network.ifr_name, interface);
929
ret = ioctl(sd, SIOCGIFFLAGS, &network);
930
if(ret == -1){
931
perror("ioctl SIOCGIFFLAGS");
932
exitcode = EXIT_FAILURE;
933
goto end;
934
}
935
if((network.ifr_flags & IFF_UP) == 0){
936
network.ifr_flags |= IFF_UP;
937
ret = ioctl(sd, SIOCSIFFLAGS, &network);
938
if(ret == -1){
939
perror("ioctl SIOCSIFFLAGS");
940
exitcode = EXIT_FAILURE;
941
goto end;
942
}
943
}
944
ret = (int)TEMP_FAILURE_RETRY(close(sd));
945
if(ret == -1){
946
perror("close");
947
}
948
}
949
950
uid = getuid();
951
gid = getgid();
952
953
ret = setuid(uid);
954
if (ret == -1){
955
perror("setuid");
956
}
957
958
setgid(gid);
959
if (ret == -1){
960
perror("setgid");
961
}
962
963
ret = init_gnutls_global(&mc, pubkey, seckey);
964
if (ret == -1){
965
fprintf(stderr, "init_gnutls_global failed\n");
966
exitcode = EXIT_FAILURE;
967
goto end;
968
} else {
969
gnutls_initalized = true;
970
}
971
972
if(mkdtemp(tempdir) == NULL){
973
perror("mkdtemp");
974
tempdir[0] = '\0';
975
goto end;
976
}
977
978
if(not init_gpgme(&mc, pubkey, seckey, tempdir)){
979
fprintf(stderr, "gpgme_initalized failed\n");
980
exitcode = EXIT_FAILURE;
981
goto end;
982
} else {
983
gpgme_initalized = true;
682
.dh_bits = 1024, .priority = "SECURE256"};
683
684
debug_int = debug ? 1 : 0;
685
while (true){
686
struct option long_options[] = {
687
{"debug", no_argument, &debug_int, 1},
688
{"connect", required_argument, NULL, 'c'},
689
{"interface", required_argument, NULL, 'i'},
690
{"keydir", required_argument, NULL, 'd'},
691
{"seckey", required_argument, NULL, 's'},
692
{"pubkey", required_argument, NULL, 'p'},
693
{"dh-bits", required_argument, NULL, 'D'},
694
{"priority", required_argument, NULL, 'P'},
695
{0, 0, 0, 0} };
696
697
int option_index = 0;
698
ret = getopt_long (argc, argv, "i:", long_options,
699
&option_index);
700
701
if (ret == -1){
702
break;
703
}
704
705
switch(ret){
706
case 0:
707
break;
708
case 'i':
709
interface = optarg;
710
break;
711
case 'c':
712
connect_to = optarg;
713
break;
714
case 'd':
715
keydir = optarg;
716
break;
717
case 'p':
718
pubkeyfile = optarg;
719
break;
720
case 's':
721
seckeyfile = optarg;
722
break;
723
case 'D':
724
errno = 0;
725
mc.dh_bits = (unsigned int) strtol(optarg, NULL, 10);
726
if (errno){
727
perror("strtol");
728
exit(EXIT_FAILURE);
729
}
730
break;
731
case 'P':
732
mc.priority = optarg;
733
break;
734
case '?':
735
default:
736
exit(EXIT_FAILURE);
737
}
738
}
739
debug = debug_int ? true : false;
740
741
pubkeyfile = combinepath(keydir, pubkeyfile);
742
if (pubkeyfile == NULL){
743
perror("combinepath");
744
returncode = EXIT_FAILURE;
745
goto exit;
746
}
747
748
seckeyfile = combinepath(keydir, seckeyfile);
749
if (seckeyfile == NULL){
750
perror("combinepath");
751
goto exit;
984
752
}
985
753
986
754
if_index = (AvahiIfIndex) if_nametoindex(interface);
995
763
char *address = strrchr(connect_to, ':');
996
764
if(address == NULL){
997
765
fprintf(stderr, "No colon in address\n");
998
exitcode = EXIT_FAILURE;
999
goto end;
766
exit(EXIT_FAILURE);
1000
767
}
1001
768
errno = 0;
1002
769
uint16_t port = (uint16_t) strtol(address+1, NULL, 10);
1003
770
if(errno){
1004
771
perror("Bad port number");
1005
exitcode = EXIT_FAILURE;
1006
goto end;
772
exit(EXIT_FAILURE);
1007
773
}
1008
774
*address = '\0';
1009
775
address = connect_to;
1010
776
ret = start_mandos_communication(address, port, if_index, &mc);
1011
777
if(ret < 0){
1012
exitcode = EXIT_FAILURE;
778
exit(EXIT_FAILURE);
1013
779
} else {
1014
exitcode = EXIT_SUCCESS;
1015
}
1016
goto end;
1017
}
780
exit(EXIT_SUCCESS);
781
}
782
}
783
784
sd = socket(PF_INET6, SOCK_DGRAM, IPPROTO_IP);
785
if(sd < 0) {
786
perror("socket");
787
returncode = EXIT_FAILURE;
788
goto exit;
789
}
790
strcpy(network.ifr_name, interface); /* Spurious warning */
791
ret = ioctl(sd, SIOCGIFFLAGS, &network);
792
if(ret == -1){
793
794
perror("ioctl SIOCGIFFLAGS");
795
returncode = EXIT_FAILURE;
796
goto exit;
797
}
798
if((network.ifr_flags & IFF_UP) == 0){
799
network.ifr_flags |= IFF_UP;
800
ret = ioctl(sd, SIOCSIFFLAGS, &network);
801
if(ret == -1){
802
perror("ioctl SIOCSIFFLAGS");
803
returncode = EXIT_FAILURE;
804
goto exit;
805
}
806
}
807
close(sd);
1018
808
1019
809
if (not debug){
1020
810
avahi_set_log_function(empty_log);
1021
811
}
1022
812
1023
/* Initialize the pseudo-RNG for Avahi */
813
/* Initialize the psuedo-RNG */
1024
814
srand((unsigned int) time(NULL));
1025
1026
/* Allocate main Avahi loop object */
1027
mc.simple_poll = avahi_simple_poll_new();
1028
if (mc.simple_poll == NULL) {
1029
fprintf(stderr, "Avahi: Failed to create simple poll"
1030
" object.\n");
1031
exitcode = EXIT_FAILURE;
1032
goto end;
1033
}
1034
1035
{
1036
AvahiServerConfig config;
1037
/* Do not publish any local Zeroconf records */
1038
avahi_server_config_init(&config);
1039
config.publish_hinfo = 0;
1040
config.publish_addresses = 0;
1041
config.publish_workstation = 0;
1042
config.publish_domain = 0;
1043
1044
/* Allocate a new server */
1045
mc.server = avahi_server_new(avahi_simple_poll_get
1046
(mc.simple_poll), &config, NULL,
1047
NULL, &error);
1048
1049
/* Free the Avahi configuration data */
1050
avahi_server_config_free(&config);
1051
}
1052
1053
/* Check if creating the Avahi server object succeeded */
1054
if (mc.server == NULL) {
1055
fprintf(stderr, "Failed to create Avahi server: %s\n",
815
816
/* Allocate main loop object */
817
if (!(mc.simple_poll = avahi_simple_poll_new())) {
818
fprintf(stderr, "Failed to create simple poll object.\n");
819
returncode = EXIT_FAILURE;
820
goto exit;
821
}
822
823
/* Do not publish any local records */
824
avahi_server_config_init(&config);
825
config.publish_hinfo = 0;
826
config.publish_addresses = 0;
827
config.publish_workstation = 0;
828
config.publish_domain = 0;
829
830
/* Allocate a new server */
831
mc.server=avahi_server_new(avahi_simple_poll_get(mc.simple_poll),
832
&config, NULL, NULL, &error);
833
834
/* Free the configuration data */
835
avahi_server_config_free(&config);
836
837
/* Check if creating the server object succeeded */
838
if (!mc.server) {
839
fprintf(stderr, "Failed to create server: %s\n",
1056
840
avahi_strerror(error));
1057
exitcode = EXIT_FAILURE;
1058
goto end;
841
returncode = EXIT_FAILURE;
842
goto exit;
1059
843
}
1060
844
1061
/* Create the Avahi service browser */
845
/* Create the service browser */
1062
846
sb = avahi_s_service_browser_new(mc.server, if_index,
1063
847
AVAHI_PROTO_INET6,
1064
848
"_mandos._tcp", NULL, 0,
1065
849
browse_callback, &mc);
1066
if (sb == NULL) {
850
if (!sb) {
1067
851
fprintf(stderr, "Failed to create service browser: %s\n",
1068
852
avahi_strerror(avahi_server_errno(mc.server)));
1069
exitcode = EXIT_FAILURE;
1070
goto end;
853
returncode = EXIT_FAILURE;
854
goto exit;
1071
855
}
1072
856
1073
857
/* Run the main loop */
1074
858
1075
859
if (debug){
1076
fprintf(stderr, "Starting Avahi loop search\n");
860
fprintf(stderr, "Starting avahi loop search\n");
1077
861
}
1078
862
1079
863
avahi_simple_poll_loop(mc.simple_poll);
1080
864
1081
end:
1082
865
exit:
866
1083
867
if (debug){
1084
868
fprintf(stderr, "%s exiting\n", argv[0]);
1085
869
}
1086
870
1087
871
/* Cleanup things */
1088
if (sb != NULL)
872
if (sb)
1089
873
avahi_s_service_browser_free(sb);
1090
874
1091
if (mc.server != NULL)
875
if (mc.server)
1092
876
avahi_server_free(mc.server);
1093
1094
if (mc.simple_poll != NULL)
877
878
if (mc.simple_poll)
1095
879
avahi_simple_poll_free(mc.simple_poll);
1096
1097
if (gnutls_initalized){
1098
gnutls_certificate_free_credentials(mc.cred);
1099
gnutls_global_deinit ();
1100
gnutls_dh_params_deinit(mc.dh_params);
1101
}
1102
1103
if(gpgme_initalized){
1104
gpgme_release(mc.ctx);
1105
}
1106
1107
/* Removes the temp directory used by GPGME */
1108
if(tempdir[0] != '\0'){
1109
DIR *d;
1110
struct dirent *direntry;
1111
d = opendir(tempdir);
1112
if(d == NULL){
1113
perror("opendir");
1114
} else {
1115
while(true){
1116
direntry = readdir(d);
1117
if(direntry == NULL){
1118
break;
1119
}
1120
if (direntry->d_type == DT_REG){
1121
char *fullname = NULL;
1122
ret = asprintf(&fullname, "%s/%s", tempdir,
1123
direntry->d_name);
1124
if(ret < 0){
1125
perror("asprintf");
1126
continue;
1127
}
1128
ret = unlink(fullname);
1129
if(ret == -1){
1130
fprintf(stderr, "unlink(\"%s\"): %s",
1131
fullname, strerror(errno));
1132
}
1133
free(fullname);
1134
}
1135
}
1136
closedir(d);
1137
}
1138
ret = rmdir(tempdir);
1139
if(ret == -1){
1140
perror("rmdir");
1141
}
1142
}
1143
1144
return exitcode;
880
free(pubkeyfile);
881
free(seckeyfile);
882
883
return returncode;
1145
884
}
Loggerhead is a web-based interface for Breezy
Version: 2.0.2.dev0