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