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