3 I've been hacking together a way to use rsync with OpenSSL, and have
4 attached my current patch against a recent CVS tree. The details of
5 this implementation are:
7 1. The SSL code is added as a "layer" that is forked into its own
10 2. An SSL connection is established by the client issuing the
15 And, if the daemon allows SSL, it replies with
19 At which point both sides begin negotiating the SSL connection.
20 Servers that can't or don't want to use SSL just treat it as a
21 normal unknown command.
23 3. The SSL code is meant to be unobtrusive, and when this patch is
24 applied the program may still be built with no SSL code.
26 4. There are a number of details not implemented.
28 All warnings apply; I don't do C programming all that often, so I
29 can't say if I've left any cleanup/compatibility errors in the code.
31 To use this patch, run these commands for a successful build:
33 patch -p1 <patches/openssl-support.diff
38 diff --git a/Makefile.in b/Makefile.in
41 @@ -40,7 +40,7 @@ OBJS3=progress.o pipe.o
42 DAEMON_OBJ = params.o loadparm.o clientserver.o access.o connection.o authenticate.o
43 popt_OBJS=popt/findme.o popt/popt.o popt/poptconfig.o \
44 popt/popthelp.o popt/poptparse.o
45 -OBJS=$(OBJS1) $(OBJS2) $(OBJS3) $(DAEMON_OBJ) $(LIBOBJ) $(ZLIBOBJ) @BUILD_POPT@
46 +OBJS=$(OBJS1) $(OBJS2) $(OBJS3) $(DAEMON_OBJ) $(LIBOBJ) $(ZLIBOBJ) @BUILD_POPT@ @SSL_OBJS@
48 TLS_OBJ = tls.o syscall.o lib/compat.o lib/snprintf.o lib/permstring.o lib/sysxattrs.o @BUILD_POPT@
50 diff --git a/cleanup.c b/cleanup.c
60 extern int keep_partial;
61 extern int got_xfer_error;
62 extern char *partial_dir;
63 @@ -121,6 +124,14 @@ NORETURN void _exit_cleanup(int code, const char *file, int line)
78 diff --git a/clientserver.c b/clientserver.c
81 @@ -30,6 +30,9 @@ extern int am_sender;
88 extern int rsync_port;
89 extern int ignore_errors;
90 extern int kluge_around_eof;
91 @@ -115,8 +118,18 @@ int start_socket_client(char *host, int remote_argc, char *remote_argv[],
92 set_socket_options(fd, sockopts);
94 ret = start_inband_exchange(fd, fd, user, remote_argc, remote_argv);
100 + int f_in = get_tls_rfd();
101 + int f_out = get_tls_wfd();
102 + return client_run(f_in, f_out, -1, argc, argv);
106 - return ret ? ret : client_run(fd, fd, -1, argc, argv);
107 + return client_run(fd, fd, -1, argc, argv);
110 static int exchange_protocols(int f_in, int f_out, char *buf, size_t bufsiz, int am_client)
111 @@ -259,6 +272,32 @@ int start_inband_exchange(int f_in, int f_out, const char *user, int argc, char
113 print_child_argv("sending daemon args:", sargs);
117 + io_printf(f_out, "#starttls\n");
119 + if (!read_line_old(f_in, line, sizeof line)) {
120 + rprintf(FERROR, "rsync: did not receive reply to #starttls\n");
123 + if (strncmp(line, "@ERROR", 6) == 0) {
124 + rprintf(FERROR, "%s\n", line);
127 + if (strcmp(line, "@RSYNCD: starttls") == 0)
129 + rprintf(FINFO, "%s\n", line);
131 + if (start_tls(f_in, f_out)) {
132 + rprintf(FERROR, "rsync: error during SSL handshake: %s\n",
136 + f_in = get_tls_rfd();
137 + f_out = get_tls_wfd();
141 io_printf(f_out, "%.*s\n", modlen, modname);
143 /* Old servers may just drop the connection here,
144 @@ -284,6 +323,10 @@ int start_inband_exchange(int f_in, int f_out, const char *user, int argc, char
145 * server to terminate the listing of modules.
146 * We don't want to go on and transfer
147 * anything; just exit. */
155 @@ -291,6 +334,10 @@ int start_inband_exchange(int f_in, int f_out, const char *user, int argc, char
156 rprintf(FERROR, "%s\n", line);
157 /* This is always fatal; the server will now
158 * close the socket. */
166 @@ -835,6 +882,9 @@ int start_daemon(int f_in, int f_out)
167 if (exchange_protocols(f_in, f_out, line, sizeof line, 0) < 0)
174 if (!read_line_old(f_in, line, sizeof line))
176 @@ -846,6 +896,20 @@ int start_daemon(int f_in, int f_out)
181 + if (use_ssl && strcmp(line, "#starttls") == 0) {
182 + io_printf(f_out, "@RSYNCD: starttls\n");
183 + if (start_tls(f_in, f_out)) {
184 + rprintf(FLOG, "SSL connection failed: %s\n",
188 + f_in = get_tls_rfd();
189 + f_out = get_tls_wfd();
195 /* it's some sort of command that I don't understand */
196 io_printf(f_out, "@ERROR: Unknown command '%s'\n", line);
197 diff --git a/configure.in b/configure.in
200 @@ -295,6 +295,21 @@ if test x"$enable_locale" != x"no"; then
201 AC_DEFINE(CONFIG_LOCALE)
204 +AC_ARG_ENABLE(openssl,
205 + AC_HELP_STRING([--enable-openssl], [compile SSL support with OpenSSL.]))
207 +if test "x$enable_openssl" != xno
210 + AC_CHECK_LIB(ssl, SSL_library_init, , [have_ssl=no])
211 + if test "x$have_ssl" = xyes
213 + AC_DEFINE(HAVE_OPENSSL, 1, [true if you want to use SSL.])
219 AC_MSG_CHECKING([whether to call shutdown on all sockets])
221 *cygwin* ) AC_MSG_RESULT(yes)
222 diff --git a/options.c b/options.c
225 @@ -183,6 +183,14 @@ int logfile_format_has_o_or_i = 0;
226 int always_checksum = 0;
231 +char *ssl_cert_path = NULL;
232 +char *ssl_key_path = NULL;
233 +char *ssl_key_passwd = NULL;
234 +char *ssl_ca_path = NULL;
237 #define MAX_BATCH_NAME_LEN 256 /* Must be less than MAXPATHLEN-13 */
238 char *batch_name = NULL;
240 @@ -222,6 +230,7 @@ static void print_rsync_version(enum logcode f)
241 char const *links = "no ";
242 char const *iconv = "no ";
243 char const *ipv6 = "no ";
244 + char const *ssl = "no ";
245 STRUCT_STAT *dumstat;
247 #if SUBPROTOCOL_VERSION != 0
248 @@ -251,6 +260,9 @@ static void print_rsync_version(enum logcode f)
256 rprintf(f, "%s version %s protocol version %d%s\n",
257 RSYNC_NAME, RSYNC_VERSION, PROTOCOL_VERSION, subprotocol);
258 @@ -264,8 +276,8 @@ static void print_rsync_version(enum logcode f)
259 (int)(sizeof (int64) * 8));
260 rprintf(f, " %ssocketpairs, %shardlinks, %ssymlinks, %sIPv6, batchfiles, %sinplace,\n",
261 got_socketpair, hardlinks, links, ipv6, have_inplace);
262 - rprintf(f, " %sappend, %sACLs, %sxattrs, %siconv\n",
263 - have_inplace, acls, xattrs, iconv);
264 + rprintf(f, " %sappend, %sACLs, %sxattrs, %siconv, %sSSL\n",
265 + have_inplace, acls, xattrs, iconv, ssl);
267 #ifdef MAINTAINER_MODE
268 rprintf(f, "Panic Action: \"%s\"\n", get_panic_action());
269 @@ -427,6 +439,13 @@ void usage(enum logcode F)
271 rprintf(F," -4, --ipv4 prefer IPv4\n");
272 rprintf(F," -6, --ipv6 prefer IPv6\n");
274 + rprintf(F," --ssl allow socket connections to use SSL\n");
275 + rprintf(F," --ssl-cert=FILE path to daemon's SSL certificate\n");
276 + rprintf(F," --ssl-key=FILE path to daemon's SSL private key\n");
277 + rprintf(F," --ssl-key-passwd=PASS password for PEM-encoded private key\n");
278 + rprintf(F," --ssl-ca-certs=FILE path to trusted CA certificates\n");
280 rprintf(F," --version print version number\n");
281 rprintf(F,"(-h) --help show this help (-h works with no other options)\n");
283 @@ -440,7 +459,7 @@ enum {OPT_VERSION = 1000, OPT_DAEMON, OPT_SENDER, OPT_EXCLUDE, OPT_EXCLUDE_FROM,
284 OPT_FILTER, OPT_COMPARE_DEST, OPT_COPY_DEST, OPT_LINK_DEST, OPT_HELP,
285 OPT_INCLUDE, OPT_INCLUDE_FROM, OPT_MODIFY_WINDOW, OPT_MIN_SIZE, OPT_CHMOD,
286 OPT_READ_BATCH, OPT_WRITE_BATCH, OPT_ONLY_WRITE_BATCH, OPT_MAX_SIZE,
287 - OPT_NO_D, OPT_APPEND,
288 + OPT_NO_D, OPT_APPEND, OPT_USE_SSL,
289 OPT_SERVER, OPT_REFUSED_BASE = 9000};
291 static struct poptOption long_options[] = {
292 @@ -626,6 +645,13 @@ static struct poptOption long_options[] = {
293 {"checksum-seed", 0, POPT_ARG_INT, &checksum_seed, 0, 0, 0 },
294 {"server", 0, POPT_ARG_NONE, 0, OPT_SERVER, 0, 0 },
295 {"sender", 0, POPT_ARG_NONE, 0, OPT_SENDER, 0, 0 },
297 + {"ssl", 0, POPT_ARG_NONE, 0, OPT_USE_SSL, 0, 0},
298 + {"ssl-cert", 0, POPT_ARG_STRING, &ssl_cert_path, OPT_USE_SSL, 0, 0},
299 + {"ssl-key", 0, POPT_ARG_STRING, &ssl_key_path, OPT_USE_SSL, 0, 0},
300 + {"ssl-key-passwd", 0, POPT_ARG_STRING, &ssl_key_passwd, OPT_USE_SSL, 0, 0},
301 + {"ssl-ca-certs", 0, POPT_ARG_STRING, &ssl_ca_path, OPT_USE_SSL, 0, 0},
303 /* All the following options switch us into daemon-mode option-parsing. */
304 {"config", 0, POPT_ARG_STRING, 0, OPT_DAEMON, 0, 0 },
305 {"daemon", 0, POPT_ARG_NONE, 0, OPT_DAEMON, 0, 0 },
306 @@ -651,6 +677,13 @@ static void daemon_usage(enum logcode F)
307 rprintf(F," -v, --verbose increase verbosity\n");
308 rprintf(F," -4, --ipv4 prefer IPv4\n");
309 rprintf(F," -6, --ipv6 prefer IPv6\n");
311 + rprintf(F," --ssl allow socket connections to use SSL\n");
312 + rprintf(F," --ssl-cert=FILE path to daemon's SSL certificate\n");
313 + rprintf(F," --ssl-key=FILE path to daemon's SSL private key\n");
314 + rprintf(F," --ssl-key-passwd=PASS password for PEM-encoded private key\n");
315 + rprintf(F," --ssl-ca-certs=FILE path to trusted CA certificates\n");
317 rprintf(F," --help show this help screen\n");
320 @@ -675,6 +708,13 @@ static struct poptOption long_daemon_options[] = {
321 {"protocol", 0, POPT_ARG_INT, &protocol_version, 0, 0, 0 },
322 {"server", 0, POPT_ARG_NONE, &am_server, 0, 0, 0 },
323 {"temp-dir", 'T', POPT_ARG_STRING, &tmpdir, 0, 0, 0 },
325 + {"ssl", 0, POPT_ARG_NONE, 0, OPT_USE_SSL, 0, 0},
326 + {"ssl-cert", 0, POPT_ARG_STRING, &ssl_cert_path, OPT_USE_SSL, 0, 0},
327 + {"ssl-key", 0, POPT_ARG_STRING, &ssl_key_path, OPT_USE_SSL, 0, 0},
328 + {"ssl-key-passwd", 0, POPT_ARG_STRING, &ssl_key_passwd, OPT_USE_SSL, 0, 0},
329 + {"ssl-ca-certs", 0, POPT_ARG_STRING, &ssl_ca_path, OPT_USE_SSL, 0, 0},
331 {"verbose", 'v', POPT_ARG_NONE, 0, 'v', 0, 0 },
332 {"no-verbose", 0, POPT_ARG_VAL, &verbose, 0, 0, 0 },
333 {"no-v", 0, POPT_ARG_VAL, &verbose, 0, 0, 0 },
334 @@ -949,6 +989,12 @@ int parse_arguments(int *argc_p, const char ***argv_p, int frommain)
346 "rsync: %s: %s (in daemon mode)\n",
347 @@ -972,6 +1018,17 @@ int parse_arguments(int *argc_p, const char ***argv_p, int frommain)
348 exit_cleanup(RERR_SYNTAX);
354 + snprintf(err_buf, sizeof(err_buf),
355 + "Openssl error: %s\n",
362 *argv_p = argv = poptGetArgs(pc);
363 *argc_p = argc = count_args(argv);
365 @@ -1224,6 +1281,12 @@ int parse_arguments(int *argc_p, const char ***argv_p, int frommain)
376 /* A large opt value means that set_refuse_options()
377 * turned this option off. */
378 @@ -1538,6 +1601,17 @@ int parse_arguments(int *argc_p, const char ***argv_p, int frommain)
379 if (delay_updates && !partial_dir)
380 partial_dir = tmp_partialdir;
385 + snprintf(err_buf, sizeof(err_buf),
386 + "Openssl error: %s\n",
394 #ifdef HAVE_FTRUNCATE
396 @@ -2010,10 +2084,27 @@ char *check_for_hostspec(char *s, char **host_ptr, int *port_ptr)
401 - if (port_ptr && strncasecmp(URL_PREFIX, s, strlen(URL_PREFIX)) == 0) {
402 + int url_prefix_len = sizeof URL_PREFIX - 1;
405 + url_prefix_len = 0;
406 + else if (strncasecmp(URL_PREFIX, s, url_prefix_len) != 0) {
408 + url_prefix_len = sizeof SSL_URL_PREFIX - 1;
409 + if (strncasecmp(SSL_URL_PREFIX, s, url_prefix_len) != 0)
410 + url_prefix_len = 0;
417 + url_prefix_len = 0;
420 + if (url_prefix_len) {
422 - s += strlen(URL_PREFIX);
423 + s += url_prefix_len;
424 if ((p = strchr(s, '/')) != NULL) {
427 diff --git a/rsync.h b/rsync.h
432 #define DEFAULT_LOCK_FILE "/var/run/rsyncd.lock"
433 #define URL_PREFIX "rsync://"
434 +#define SSL_URL_PREFIX "rsyncs://"
436 #define SYMLINK_PREFIX "/rsyncd-munged/"
437 #define SYMLINK_PREFIX_LEN ((int)sizeof SYMLINK_PREFIX - 1)
438 @@ -536,6 +537,11 @@ typedef unsigned int size_t;
439 # define SIZEOF_INT64 SIZEOF_OFF_T
443 +#include <openssl/ssl.h>
444 +#include <openssl/err.h>
450 diff --git a/ssl.c b/ssl.c
455 +/* -*- c-file-style: "linux" -*-
456 + * ssl.c: operations for negotiating SSL rsync connections.
458 + * Copyright (C) 2003 Casey Marshall <rsdio@metastatic.org>
460 + * This program is free software; you can redistribute it and/or modify
461 + * it under the terms of the GNU General Public License as published by
462 + * the Free Software Foundation; either version 2 of the License, or
463 + * (at your option) any later version.
465 + * This program is distributed in the hope that it will be useful,
466 + * but WITHOUT ANY WARRANTY; without even the implied warranty of
467 + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
468 + * GNU General Public License for more details.
470 + * You should have received a copy of the GNU General Public License
471 + * along with this program; if not, write to the Free Software
472 + * Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
477 +#ifdef HAVE_SYS_SELECT_H
478 +#include <sys/select.h>
480 +#include <sys/time.h>
481 +#include <sys/types.h>
486 +#define BUF_SIZE 1024
489 +extern int am_daemon;
490 +extern int am_server;
492 +extern char *ssl_cert_path;
493 +extern char *ssl_key_path;
494 +extern char *ssl_key_passwd;
495 +extern char *ssl_ca_path;
497 +static SSL_CTX *ssl_ctx;
499 +static int tls_read[2] = { -1, -1 };
500 +static int tls_write[2] = { -1, -1 };
501 +static int ssl_running;
502 +static int ssl_pid = -1;
504 +#ifdef HAVE_SIGACTION
505 +static struct sigaction sigact;
509 + * A non-interactive callback to be passed to SSL_CTX_set_default_password_cb,
510 + * which merely copies the value of ssl_key_passwd into buf. This is
511 + * used for when the private key password is supplied via an option.
513 +static int default_password_cb(char *buf, int n, UNUSED(int f), UNUSED(void *u))
515 + if (ssl_key_passwd == NULL || n < (int)strlen(ssl_key_passwd))
517 + strncpy(buf, ssl_key_passwd, n-1);
518 + return strlen(ssl_key_passwd);
522 + * If verbose, this method traces the status of the SSL handshake.
524 +static void info_callback(const SSL *ssl, int cb, int val)
531 + cbs = "SSL_CB_LOOP";
534 + cbs = "SSL_CB_EXIT";
537 + cbs = "SSL_CB_READ";
540 + cbs = "SSL_CB_WRITE";
543 + cbs = "SSL_CB_ALERT";
545 + case SSL_CB_READ_ALERT:
546 + cbs = "SSL_CB_READ_ALERT";
548 + case SSL_CB_WRITE_ALERT:
549 + cbs = "SSL_CB_WRITE_ALERT";
551 + case SSL_CB_ACCEPT_LOOP:
552 + cbs = "SSL_CB_ACCEPT_LOOP";
554 + case SSL_CB_ACCEPT_EXIT:
555 + cbs = "SSL_CB_ACCEPT_EXIT";
557 + case SSL_CB_CONNECT_LOOP:
558 + cbs = "SSL_CB_CONNECT_LOOP";
560 + case SSL_CB_CONNECT_EXIT:
561 + cbs = "SSL_CB_CONNECT_EXIT";
563 + case SSL_CB_HANDSHAKE_START:
564 + cbs = "SSL_CB_HANDSHAKE_START";
566 + case SSL_CB_HANDSHAKE_DONE:
567 + cbs = "SSL_CB_HANDSHAKE_DONE";
570 + snprintf(buf, sizeof buf, "??? (%d)", cb);
575 + rprintf(FLOG, "SSL: info_callback(%p,%s,%d)\n", ssl, cbs, val);
576 + if (cb == SSL_CB_HANDSHAKE_DONE) {
577 + SSL_CIPHER_description(SSL_get_current_cipher((SSL*)ssl),
579 + rprintf(FLOG, "SSL: cipher: %s", buf);
585 + * Initializes the SSL context for TLSv1 connections; returns zero on
592 + SSL_library_init();
593 + SSL_load_error_strings();
594 + ssl_ctx = SSL_CTX_new(TLSv1_method());
597 + SSL_CTX_set_info_callback(ssl_ctx, info_callback);
599 + /* Sets the certificate sent to the other party. */
600 + if (ssl_cert_path != NULL
601 + && SSL_CTX_use_certificate_file(ssl_ctx, ssl_cert_path,
602 + SSL_FILETYPE_PEM) != 1)
604 + /* Set up the simple non-interactive callback if the password
605 + * was supplied on the command line. */
606 + if (ssl_key_passwd != NULL)
607 + SSL_CTX_set_default_passwd_cb(ssl_ctx, default_password_cb);
608 + /* Sets the private key that matches the public certificate. */
609 + if (ssl_key_path != NULL) {
610 + if (SSL_CTX_use_PrivateKey_file(ssl_ctx, ssl_key_path,
611 + SSL_FILETYPE_PEM) != 1)
613 + if (SSL_CTX_check_private_key(ssl_ctx) != 1)
616 + if (ssl_ca_path != NULL
617 + && !SSL_CTX_load_verify_locations(ssl_ctx, ssl_ca_path, NULL))
624 + * Returns the error string for the current SSL error, if any.
626 +char *get_ssl_error(void)
628 + return ERR_error_string(ERR_get_error(), NULL);
632 + * Returns the input file descriptor for the SSL connection.
634 +int get_tls_rfd(void)
636 + return tls_read[0];
640 + * Returns the output file descriptor for the SSL connection.
642 +int get_tls_wfd(void)
644 + return tls_write[1];
648 + * Signal handler that ends the SSL connection.
650 +static RETSIGTYPE tls_sigusr1(int UNUSED(val))
661 + * Negotiates the TLS connection, creates a socket pair for communicating
662 + * with the rsync process, then forks into a new process that will handle
663 + * the communication.
665 + * 0 is returned on success.
667 +int start_tls(int f_in, int f_out)
671 + unsigned char buf1[BUF_SIZE], buf2[BUF_SIZE];
672 + int avail1 = 0, avail2 = 0, write1 = 0, write2 = 0;
675 + if (fd_pair(tls_read))
677 + if (fd_pair(tls_write))
680 + set_blocking(tls_read[0]);
681 + set_blocking(tls_read[1]);
682 + set_blocking(tls_write[0]);
683 + set_blocking(tls_write[1]);
684 + set_blocking(f_in);
685 + set_blocking(f_out);
687 + ssl_pid = do_fork();
690 + if (ssl_pid != 0) {
691 + close(tls_write[0]);
692 + close(tls_read[1]);
696 + SIGACTION(SIGUSR1, tls_sigusr1);
697 + ssl = SSL_new(ssl_ctx);
700 + if (am_daemon || am_server)
701 + SSL_set_accept_state(ssl);
703 + SSL_set_connect_state(ssl);
704 + SSL_set_rfd(ssl, f_in);
705 + SSL_set_wfd(ssl, f_out);
707 + tls_fd = SSL_get_fd(ssl);
709 + n = MAX(tls_read[1], n);
710 + n = MAX(tls_fd, n) + 1;
713 + while (ssl_running) {
716 + FD_SET(tls_write[0], &rd);
717 + FD_SET(tls_read[1], &wd);
718 + FD_SET(tls_fd, &rd);
719 + FD_SET(tls_fd, &wd);
721 + r = select(n, &rd, &wd, NULL, NULL);
723 + if (r == -1 && errno == EINTR)
725 + if (FD_ISSET(tls_write[0], &rd)) {
726 + r = read(tls_write[0], buf1+avail1, BUF_SIZE-avail1);
730 + rprintf(FERROR, "pipe read error: %s\n",
735 + if (FD_ISSET(tls_fd, &rd)) {
736 + r = SSL_read(ssl, buf2+avail2, BUF_SIZE-avail2);
740 + switch (SSL_get_error(ssl, r)) {
741 + case SSL_ERROR_ZERO_RETURN:
743 + case SSL_ERROR_WANT_READ:
744 + case SSL_ERROR_WANT_WRITE:
746 + case SSL_ERROR_SYSCALL:
748 + rprintf(FERROR, "SSL spurious EOF\n");
750 + rprintf(FERROR, "SSL I/O error: %s\n",
753 + case SSL_ERROR_SSL:
754 + rprintf(FERROR, "SSL: %s\n",
755 + ERR_error_string(ERR_get_error(), NULL));
758 + rprintf(FERROR, "unexpected ssl error %d\n", r);
763 + if (FD_ISSET(tls_read[1], &wd) && write2 < avail2) {
764 + r = write(tls_read[1], buf2+write2, avail2-write2);
768 + rprintf(FERROR, "pipe write error: %s\n",
773 + if (FD_ISSET(tls_fd, &wd) && write1 < avail1) {
774 + r = SSL_write(ssl, buf1+write1, avail1-write1);
778 + switch (SSL_get_error(ssl, r)) {
779 + case SSL_ERROR_ZERO_RETURN:
781 + case SSL_ERROR_WANT_READ:
782 + case SSL_ERROR_WANT_WRITE:
784 + case SSL_ERROR_SYSCALL:
786 + rprintf(FERROR, "SSL: spurious EOF\n");
788 + rprintf(FERROR, "SSL: I/O error: %s\n",
791 + case SSL_ERROR_SSL:
792 + rprintf(FERROR, "SSL: %s\n",
793 + ERR_error_string(ERR_get_error(), NULL));
796 + rprintf(FERROR, "unexpected ssl error %d\n", r);
801 + if (avail1 == write1)
802 + avail1 = write1 = 0;
803 + if (avail2 == write2)
804 + avail2 = write2 = 0;
807 + /* XXX I'm pretty sure that there is a lot that I am not considering
808 + here. Bugs? Yes, probably. */
810 + /* We're finished. */
812 + close(tls_read[1]);
813 + close(tls_write[0]);
818 + * Ends the TLS connection.
823 + kill(ssl_pid, SIGUSR1);