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