1b9cbc85dSRick Macklem /*- 24d846d26SWarner Losh * SPDX-License-Identifier: BSD-2-Clause 3b9cbc85dSRick Macklem * 4b9cbc85dSRick Macklem * Copyright (c) 2008 Isilon Inc http://www.isilon.com/ 5b9cbc85dSRick Macklem * Authors: Doug Rabson <dfr@rabson.org> 6b9cbc85dSRick Macklem * Developed with Red Inc: Alfred Perlstein <alfred@freebsd.org> 7b9cbc85dSRick Macklem * 8b9cbc85dSRick Macklem * Redistribution and use in source and binary forms, with or without 9b9cbc85dSRick Macklem * modification, are permitted provided that the following conditions 10b9cbc85dSRick Macklem * are met: 11b9cbc85dSRick Macklem * 1. Redistributions of source code must retain the above copyright 12b9cbc85dSRick Macklem * notice, this list of conditions and the following disclaimer. 13b9cbc85dSRick Macklem * 2. Redistributions in binary form must reproduce the above copyright 14b9cbc85dSRick Macklem * notice, this list of conditions and the following disclaimer in the 15b9cbc85dSRick Macklem * documentation and/or other materials provided with the distribution. 16b9cbc85dSRick Macklem * 17b9cbc85dSRick Macklem * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND 18b9cbc85dSRick Macklem * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 19b9cbc85dSRick Macklem * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 20b9cbc85dSRick Macklem * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE 21b9cbc85dSRick Macklem * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL 22b9cbc85dSRick Macklem * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS 23b9cbc85dSRick Macklem * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) 24b9cbc85dSRick Macklem * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT 25b9cbc85dSRick Macklem * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY 26b9cbc85dSRick Macklem * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 27b9cbc85dSRick Macklem * SUCH DAMAGE. 28b9cbc85dSRick Macklem */ 29b9cbc85dSRick Macklem 30b9cbc85dSRick Macklem /* 31b9cbc85dSRick Macklem * Extensively modified from /usr/src/usr.sbin/gssd.c r344402 for 32b9cbc85dSRick Macklem * the server side of kernel RPC-over-TLS by Rick Macklem. 33b9cbc85dSRick Macklem */ 34b9cbc85dSRick Macklem 35b9cbc85dSRick Macklem #include <sys/cdefs.h> 36b9cbc85dSRick Macklem __FBSDID("$FreeBSD$"); 37b9cbc85dSRick Macklem 38b9cbc85dSRick Macklem #include <sys/param.h> 39b9cbc85dSRick Macklem #include <sys/types.h> 40b9cbc85dSRick Macklem #include <sys/linker.h> 41b9cbc85dSRick Macklem #include <sys/module.h> 42b9cbc85dSRick Macklem #include <sys/queue.h> 43b9cbc85dSRick Macklem #include <sys/stat.h> 44b9cbc85dSRick Macklem #include <sys/sysctl.h> 45b9cbc85dSRick Macklem #include <sys/syslog.h> 46b9cbc85dSRick Macklem #include <sys/time.h> 471e588a9cSRick Macklem #include <sys/wait.h> 48b9cbc85dSRick Macklem #include <err.h> 49b9cbc85dSRick Macklem #include <getopt.h> 50b9cbc85dSRick Macklem #include <libutil.h> 51b9cbc85dSRick Macklem #include <netdb.h> 52b9cbc85dSRick Macklem #include <pwd.h> 53b9cbc85dSRick Macklem #include <signal.h> 54b9cbc85dSRick Macklem #include <stdarg.h> 55b9cbc85dSRick Macklem #include <stdio.h> 56b9cbc85dSRick Macklem #include <stdlib.h> 57b9cbc85dSRick Macklem #include <stdbool.h> 58b9cbc85dSRick Macklem #include <string.h> 59b9cbc85dSRick Macklem #include <unistd.h> 60b9cbc85dSRick Macklem 61b9cbc85dSRick Macklem #include <rpc/rpc.h> 62b9cbc85dSRick Macklem #include <rpc/rpc_com.h> 63b9cbc85dSRick Macklem #include <rpc/rpcsec_tls.h> 64b9cbc85dSRick Macklem 65b9cbc85dSRick Macklem #include <openssl/opensslconf.h> 66b9cbc85dSRick Macklem #include <openssl/bio.h> 67b9cbc85dSRick Macklem #include <openssl/ssl.h> 68b9cbc85dSRick Macklem #include <openssl/err.h> 69b9cbc85dSRick Macklem #include <openssl/x509v3.h> 70b9cbc85dSRick Macklem 71b9cbc85dSRick Macklem #include "rpctlssd.h" 72b9cbc85dSRick Macklem #include "rpc.tlscommon.h" 73b9cbc85dSRick Macklem 74b9cbc85dSRick Macklem #ifndef _PATH_RPCTLSSDSOCK 75b9cbc85dSRick Macklem #define _PATH_RPCTLSSDSOCK "/var/run/rpc.tlsservd.sock" 76b9cbc85dSRick Macklem #endif 77b9cbc85dSRick Macklem #ifndef _PATH_CERTANDKEY 78b9cbc85dSRick Macklem #define _PATH_CERTANDKEY "/etc/rpc.tlsservd/" 79b9cbc85dSRick Macklem #endif 80b9cbc85dSRick Macklem #ifndef _PATH_RPCTLSSDPID 81b9cbc85dSRick Macklem #define _PATH_RPCTLSSDPID "/var/run/rpc.tlsservd.pid" 82b9cbc85dSRick Macklem #endif 83b9cbc85dSRick Macklem #ifndef _PREFERRED_CIPHERS 84b9cbc85dSRick Macklem #define _PREFERRED_CIPHERS "AES128-GCM-SHA256" 85b9cbc85dSRick Macklem #endif 86b9cbc85dSRick Macklem 87b9cbc85dSRick Macklem /* Global variables also used by rpc.tlscommon.c. */ 88b9cbc85dSRick Macklem int rpctls_debug_level; 89b9cbc85dSRick Macklem bool rpctls_verbose; 90b9cbc85dSRick Macklem SSL_CTX *rpctls_ctx = NULL; 91b9cbc85dSRick Macklem const char *rpctls_verify_cafile = NULL; 92b9cbc85dSRick Macklem const char *rpctls_verify_capath = NULL; 93b9cbc85dSRick Macklem char *rpctls_crlfile = NULL; 94b9cbc85dSRick Macklem bool rpctls_gothup = false; 95b9cbc85dSRick Macklem struct ssl_list rpctls_ssllist; 96b9cbc85dSRick Macklem 97b9cbc85dSRick Macklem static struct pidfh *rpctls_pfh = NULL; 98b9cbc85dSRick Macklem static bool rpctls_do_mutual = false; 99b9cbc85dSRick Macklem static const char *rpctls_certdir = _PATH_CERTANDKEY; 100b9cbc85dSRick Macklem static bool rpctls_comparehost = false; 101b9cbc85dSRick Macklem static unsigned int rpctls_wildcard = X509_CHECK_FLAG_NO_WILDCARDS; 102b9cbc85dSRick Macklem static uint64_t rpctls_ssl_refno = 0; 103b9cbc85dSRick Macklem static uint64_t rpctls_ssl_sec = 0; 104b9cbc85dSRick Macklem static uint64_t rpctls_ssl_usec = 0; 105b9cbc85dSRick Macklem static bool rpctls_cnuser = false; 106b9cbc85dSRick Macklem static char *rpctls_dnsname; 107b9cbc85dSRick Macklem static const char *rpctls_cnuseroid = "1.3.6.1.4.1.2238.1.1.1"; 108712aac13SRick Macklem static const char *rpctls_ciphers = NULL; 1090637b12bSRick Macklem static int rpctls_mintls = TLS1_3_VERSION; 1101e588a9cSRick Macklem static int rpctls_procs = 1; 1111e588a9cSRick Macklem static char *rpctls_sockname[RPCTLS_SRV_MAXNPROCS]; 1121e588a9cSRick Macklem static pid_t rpctls_workers[RPCTLS_SRV_MAXNPROCS - 1]; 1131e588a9cSRick Macklem static bool rpctls_im_a_worker = false; 114b9cbc85dSRick Macklem 1151e588a9cSRick Macklem static void rpctls_cleanup_term(int sig); 116b9cbc85dSRick Macklem static SSL_CTX *rpctls_setup_ssl(const char *certdir); 117b9cbc85dSRick Macklem static SSL *rpctls_server(SSL_CTX *ctx, int s, 118b9cbc85dSRick Macklem uint32_t *flags, uint32_t *uidp, 119b9cbc85dSRick Macklem int *ngrps, uint32_t *gidp, X509 **certp); 120b9cbc85dSRick Macklem static int rpctls_cnname(X509 *cert, uint32_t *uidp, 121b9cbc85dSRick Macklem int *ngrps, uint32_t *gidp); 122b9cbc85dSRick Macklem static char *rpctls_getdnsname(char *dnsname); 123b9cbc85dSRick Macklem static void rpctls_huphandler(int sig __unused); 124b9cbc85dSRick Macklem 125b9cbc85dSRick Macklem extern void rpctlssd_1(struct svc_req *rqstp, SVCXPRT *transp); 126b9cbc85dSRick Macklem 127b9cbc85dSRick Macklem static struct option longopts[] = { 1280637b12bSRick Macklem { "allowtls1_2", no_argument, NULL, '2' }, 129712aac13SRick Macklem { "ciphers", required_argument, NULL, 'C' }, 130b9cbc85dSRick Macklem { "certdir", required_argument, NULL, 'D' }, 131b9cbc85dSRick Macklem { "debuglevel", no_argument, NULL, 'd' }, 132b9cbc85dSRick Macklem { "checkhost", no_argument, NULL, 'h' }, 133b9cbc85dSRick Macklem { "verifylocs", required_argument, NULL, 'l' }, 134b9cbc85dSRick Macklem { "mutualverf", no_argument, NULL, 'm' }, 1351e588a9cSRick Macklem { "numdaemons", required_argument, NULL, 'N' }, 136b9cbc85dSRick Macklem { "domain", required_argument, NULL, 'n' }, 137b9cbc85dSRick Macklem { "verifydir", required_argument, NULL, 'p' }, 138b9cbc85dSRick Macklem { "crl", required_argument, NULL, 'r' }, 139b9cbc85dSRick Macklem { "certuser", no_argument, NULL, 'u' }, 140b9cbc85dSRick Macklem { "verbose", no_argument, NULL, 'v' }, 141b9cbc85dSRick Macklem { "multiwild", no_argument, NULL, 'W' }, 142b9cbc85dSRick Macklem { "singlewild", no_argument, NULL, 'w' }, 143b9cbc85dSRick Macklem { NULL, 0, NULL, 0 } 144b9cbc85dSRick Macklem }; 145b9cbc85dSRick Macklem 146b9cbc85dSRick Macklem int 147b9cbc85dSRick Macklem main(int argc, char **argv) 148b9cbc85dSRick Macklem { 149b9cbc85dSRick Macklem /* 150b9cbc85dSRick Macklem * We provide an RPC service on a local-domain socket. The 151b9cbc85dSRick Macklem * kernel rpctls code will upcall to this daemon to do the initial 152b9cbc85dSRick Macklem * TLS handshake. 153b9cbc85dSRick Macklem */ 154b9cbc85dSRick Macklem struct sockaddr_un sun; 1551e588a9cSRick Macklem int ch, fd, i, mypos, oldmask; 156b9cbc85dSRick Macklem SVCXPRT *xprt; 157b9cbc85dSRick Macklem struct timeval tm; 158b9cbc85dSRick Macklem struct timezone tz; 159b9cbc85dSRick Macklem char hostname[MAXHOSTNAMELEN + 2]; 160b9cbc85dSRick Macklem pid_t otherpid; 161b9cbc85dSRick Macklem bool tls_enable; 162b9cbc85dSRick Macklem size_t tls_enable_len; 1631e588a9cSRick Macklem sigset_t signew; 164b9cbc85dSRick Macklem 165b9cbc85dSRick Macklem /* Check that another rpctlssd isn't already running. */ 166b9cbc85dSRick Macklem rpctls_pfh = pidfile_open(_PATH_RPCTLSSDPID, 0600, &otherpid); 167b9cbc85dSRick Macklem if (rpctls_pfh == NULL) { 168b9cbc85dSRick Macklem if (errno == EEXIST) 169b9cbc85dSRick Macklem errx(1, "rpctlssd already running, pid: %d.", otherpid); 170b9cbc85dSRick Macklem warn("cannot open or create pidfile"); 171b9cbc85dSRick Macklem } 172b9cbc85dSRick Macklem 173b9cbc85dSRick Macklem /* Check to see that the ktls is enabled. */ 174b9cbc85dSRick Macklem tls_enable_len = sizeof(tls_enable); 175b9cbc85dSRick Macklem if (sysctlbyname("kern.ipc.tls.enable", &tls_enable, &tls_enable_len, 176b9cbc85dSRick Macklem NULL, 0) != 0 || !tls_enable) 177b9cbc85dSRick Macklem errx(1, "Kernel TLS not enabled"); 178b9cbc85dSRick Macklem 179b9cbc85dSRick Macklem /* Get the time when this daemon is started. */ 180b9cbc85dSRick Macklem gettimeofday(&tm, &tz); 181b9cbc85dSRick Macklem rpctls_ssl_sec = tm.tv_sec; 182b9cbc85dSRick Macklem rpctls_ssl_usec = tm.tv_usec; 183b9cbc85dSRick Macklem 184b9cbc85dSRick Macklem /* Set the dns name for the server. */ 185b9cbc85dSRick Macklem rpctls_dnsname = rpctls_getdnsname(hostname); 186b9cbc85dSRick Macklem if (rpctls_dnsname == NULL) { 187b9cbc85dSRick Macklem strcpy(hostname, "@default.domain"); 188b9cbc85dSRick Macklem rpctls_dnsname = hostname; 189b9cbc85dSRick Macklem } 190b9cbc85dSRick Macklem 1911e588a9cSRick Macklem /* Initialize socket names. */ 1921e588a9cSRick Macklem for (i = 0; i < RPCTLS_SRV_MAXNPROCS; i++) { 1931e588a9cSRick Macklem asprintf(&rpctls_sockname[i], "%s.%d", _PATH_RPCTLSSDSOCK, i); 1941e588a9cSRick Macklem if (rpctls_sockname[i] == NULL) 1951e588a9cSRick Macklem errx(1, "Cannot malloc socknames"); 1961e588a9cSRick Macklem } 1971e588a9cSRick Macklem 198b9cbc85dSRick Macklem rpctls_verbose = false; 1991e588a9cSRick Macklem while ((ch = getopt_long(argc, argv, "2C:D:dhl:N:n:mp:r:uvWw", longopts, 200b9cbc85dSRick Macklem NULL)) != -1) { 201b9cbc85dSRick Macklem switch (ch) { 2020637b12bSRick Macklem case '2': 2030637b12bSRick Macklem rpctls_mintls = TLS1_2_VERSION; 2040637b12bSRick Macklem break; 205712aac13SRick Macklem case 'C': 206712aac13SRick Macklem rpctls_ciphers = optarg; 207712aac13SRick Macklem break; 208b9cbc85dSRick Macklem case 'D': 209b9cbc85dSRick Macklem rpctls_certdir = optarg; 210b9cbc85dSRick Macklem break; 211b9cbc85dSRick Macklem case 'd': 212b9cbc85dSRick Macklem rpctls_debug_level++; 213b9cbc85dSRick Macklem break; 214b9cbc85dSRick Macklem case 'h': 215b9cbc85dSRick Macklem rpctls_comparehost = true; 216b9cbc85dSRick Macklem break; 217b9cbc85dSRick Macklem case 'l': 218b9cbc85dSRick Macklem rpctls_verify_cafile = optarg; 219b9cbc85dSRick Macklem break; 220b9cbc85dSRick Macklem case 'm': 221b9cbc85dSRick Macklem rpctls_do_mutual = true; 222b9cbc85dSRick Macklem break; 2231e588a9cSRick Macklem case 'N': 2241e588a9cSRick Macklem rpctls_procs = atoi(optarg); 2251e588a9cSRick Macklem if (rpctls_procs < 1 || 2261e588a9cSRick Macklem rpctls_procs > RPCTLS_SRV_MAXNPROCS) 2271e588a9cSRick Macklem errx(1, "numdaemons/-N must be between 1 and " 2281e588a9cSRick Macklem "%d", RPCTLS_SRV_MAXNPROCS); 2291e588a9cSRick Macklem break; 230b9cbc85dSRick Macklem case 'n': 231b9cbc85dSRick Macklem hostname[0] = '@'; 232b9cbc85dSRick Macklem strlcpy(&hostname[1], optarg, MAXHOSTNAMELEN + 1); 233b9cbc85dSRick Macklem rpctls_dnsname = hostname; 234b9cbc85dSRick Macklem break; 235b9cbc85dSRick Macklem case 'p': 236b9cbc85dSRick Macklem rpctls_verify_capath = optarg; 237b9cbc85dSRick Macklem break; 238b9cbc85dSRick Macklem case 'r': 239b9cbc85dSRick Macklem rpctls_crlfile = optarg; 240b9cbc85dSRick Macklem break; 241b9cbc85dSRick Macklem case 'u': 242b9cbc85dSRick Macklem rpctls_cnuser = true; 243b9cbc85dSRick Macklem break; 244b9cbc85dSRick Macklem case 'v': 245b9cbc85dSRick Macklem rpctls_verbose = true; 246b9cbc85dSRick Macklem break; 247b9cbc85dSRick Macklem case 'W': 248b9cbc85dSRick Macklem if (rpctls_wildcard != X509_CHECK_FLAG_NO_WILDCARDS) 249b9cbc85dSRick Macklem errx(1, "options -w and -W are mutually " 250b9cbc85dSRick Macklem "exclusive"); 251b9cbc85dSRick Macklem rpctls_wildcard = X509_CHECK_FLAG_MULTI_LABEL_WILDCARDS; 252b9cbc85dSRick Macklem break; 253b9cbc85dSRick Macklem case 'w': 254b9cbc85dSRick Macklem if (rpctls_wildcard != X509_CHECK_FLAG_NO_WILDCARDS) 255b9cbc85dSRick Macklem errx(1, "options -w and -W are mutually " 256b9cbc85dSRick Macklem "exclusive"); 257b9cbc85dSRick Macklem rpctls_wildcard = 0; 258b9cbc85dSRick Macklem break; 259b9cbc85dSRick Macklem default: 260b9cbc85dSRick Macklem fprintf(stderr, "usage: %s " 261b4fa7fdeSRick Macklem "[-2/--allowtls1_2] " 2628d098dedSRick Macklem "[-C/--ciphers available_ciphers] " 263b9cbc85dSRick Macklem "[-D/--certdir certdir] [-d/--debuglevel] " 264b9cbc85dSRick Macklem "[-h/--checkhost] " 265b9cbc85dSRick Macklem "[-l/--verifylocs CAfile] [-m/--mutualverf] " 2661e588a9cSRick Macklem "[-N/--numdaemons num] " 267b9cbc85dSRick Macklem "[-n/--domain domain_name] " 268b9cbc85dSRick Macklem "[-p/--verifydir CApath] [-r/--crl CRLfile] " 269b9cbc85dSRick Macklem "[-u/--certuser] [-v/--verbose] [-W/--multiwild] " 270b9cbc85dSRick Macklem "[-w/--singlewild]\n", argv[0]); 271b9cbc85dSRick Macklem exit(1); 272b9cbc85dSRick Macklem } 273b9cbc85dSRick Macklem } 274b9cbc85dSRick Macklem if (rpctls_do_mutual && rpctls_verify_cafile == NULL && 275b9cbc85dSRick Macklem rpctls_verify_capath == NULL) 276b9cbc85dSRick Macklem errx(1, "-m requires the -l <CAfile> and/or " 277b9cbc85dSRick Macklem "-p <CApath> options"); 278b9cbc85dSRick Macklem if (rpctls_comparehost && (!rpctls_do_mutual || 279b9cbc85dSRick Macklem (rpctls_verify_cafile == NULL && rpctls_verify_capath == NULL))) 280b9cbc85dSRick Macklem errx(1, "-h requires the -m plus the " 281b9cbc85dSRick Macklem "-l <CAfile> and/or -p <CApath> options"); 282b9cbc85dSRick Macklem if (!rpctls_comparehost && rpctls_wildcard != 283b9cbc85dSRick Macklem X509_CHECK_FLAG_NO_WILDCARDS) 284b9cbc85dSRick Macklem errx(1, "The -w or -W options require the -h option"); 285b9cbc85dSRick Macklem if (rpctls_cnuser && (!rpctls_do_mutual || 286b9cbc85dSRick Macklem (rpctls_verify_cafile == NULL && rpctls_verify_capath == NULL))) 287b9cbc85dSRick Macklem errx(1, "-u requires the -m plus the " 288b9cbc85dSRick Macklem "-l <CAfile> and/or -p <CApath> options"); 289b9cbc85dSRick Macklem 290b9cbc85dSRick Macklem if (modfind("krpc") < 0) { 291b9cbc85dSRick Macklem /* Not present in kernel, try loading it */ 292b9cbc85dSRick Macklem if (kldload("krpc") < 0 || modfind("krpc") < 0) 293b9cbc85dSRick Macklem errx(1, "Kernel RPC is not available"); 294b9cbc85dSRick Macklem } 295b9cbc85dSRick Macklem 2961e588a9cSRick Macklem for (i = 0; i < rpctls_procs - 1; i++) 2971e588a9cSRick Macklem rpctls_workers[i] = -1; 2981e588a9cSRick Macklem mypos = 0; 2991e588a9cSRick Macklem 300b9cbc85dSRick Macklem if (rpctls_debug_level == 0) { 3011e588a9cSRick Macklem /* 3021e588a9cSRick Macklem * Temporarily block SIGTERM and SIGCHLD, so workers[] can't 3031e588a9cSRick Macklem * end up bogus. 3041e588a9cSRick Macklem */ 3051e588a9cSRick Macklem sigemptyset(&signew); 3061e588a9cSRick Macklem sigaddset(&signew, SIGTERM); 3071e588a9cSRick Macklem sigaddset(&signew, SIGCHLD); 3081e588a9cSRick Macklem sigprocmask(SIG_BLOCK, &signew, NULL); 3091e588a9cSRick Macklem 310b9cbc85dSRick Macklem if (daemon(0, 0) != 0) 311b9cbc85dSRick Macklem err(1, "Can't daemonize"); 312b9cbc85dSRick Macklem signal(SIGINT, SIG_IGN); 313b9cbc85dSRick Macklem signal(SIGQUIT, SIG_IGN); 314b9cbc85dSRick Macklem } 315b9cbc85dSRick Macklem signal(SIGPIPE, SIG_IGN); 316b9cbc85dSRick Macklem signal(SIGHUP, rpctls_huphandler); 3171e588a9cSRick Macklem signal(SIGTERM, rpctls_cleanup_term); 3181e588a9cSRick Macklem signal(SIGCHLD, rpctls_cleanup_term); 319b9cbc85dSRick Macklem 320b9cbc85dSRick Macklem pidfile_write(rpctls_pfh); 321b9cbc85dSRick Macklem 3221e588a9cSRick Macklem rpctls_syscall(RPCTLS_SYSC_SRVSTARTUP, ""); 3231e588a9cSRick Macklem 3241e588a9cSRick Macklem if (rpctls_debug_level == 0) { 3251e588a9cSRick Macklem /* Fork off the worker daemons. */ 3261e588a9cSRick Macklem for (i = 0; i < rpctls_procs - 1; i++) { 3271e588a9cSRick Macklem rpctls_workers[i] = fork(); 3281e588a9cSRick Macklem if (rpctls_workers[i] == 0) { 3291e588a9cSRick Macklem rpctls_im_a_worker = true; 3301e588a9cSRick Macklem mypos = i + 1; 3311e588a9cSRick Macklem setproctitle("server"); 3321e588a9cSRick Macklem break; 3331e588a9cSRick Macklem } else if (rpctls_workers[i] < 0) { 3341e588a9cSRick Macklem syslog(LOG_ERR, "fork: %m"); 3351e588a9cSRick Macklem } 3361e588a9cSRick Macklem } 3371e588a9cSRick Macklem 3381e588a9cSRick Macklem if (!rpctls_im_a_worker && rpctls_procs > 1) 3391e588a9cSRick Macklem setproctitle("master"); 3401e588a9cSRick Macklem } 3411e588a9cSRick Macklem sigemptyset(&signew); 3421e588a9cSRick Macklem sigaddset(&signew, SIGTERM); 3431e588a9cSRick Macklem sigaddset(&signew, SIGCHLD); 3441e588a9cSRick Macklem sigprocmask(SIG_UNBLOCK, &signew, NULL); 3451e588a9cSRick Macklem 346b9cbc85dSRick Macklem memset(&sun, 0, sizeof sun); 347b9cbc85dSRick Macklem sun.sun_family = AF_LOCAL; 3481e588a9cSRick Macklem unlink(rpctls_sockname[mypos]); 3491e588a9cSRick Macklem strcpy(sun.sun_path, rpctls_sockname[mypos]); 350b9cbc85dSRick Macklem sun.sun_len = SUN_LEN(&sun); 351b9cbc85dSRick Macklem fd = socket(AF_LOCAL, SOCK_STREAM, 0); 352b9cbc85dSRick Macklem if (fd < 0) { 353b9cbc85dSRick Macklem if (rpctls_debug_level == 0) { 354b9cbc85dSRick Macklem syslog(LOG_ERR, "Can't create local rpctlssd socket"); 355b9cbc85dSRick Macklem exit(1); 356b9cbc85dSRick Macklem } 357b9cbc85dSRick Macklem err(1, "Can't create local rpctlssd socket"); 358b9cbc85dSRick Macklem } 359b9cbc85dSRick Macklem oldmask = umask(S_IXUSR|S_IRWXG|S_IRWXO); 360b9cbc85dSRick Macklem if (bind(fd, (struct sockaddr *)&sun, sun.sun_len) < 0) { 361b9cbc85dSRick Macklem if (rpctls_debug_level == 0) { 362b9cbc85dSRick Macklem syslog(LOG_ERR, "Can't bind local rpctlssd socket"); 363b9cbc85dSRick Macklem exit(1); 364b9cbc85dSRick Macklem } 365b9cbc85dSRick Macklem err(1, "Can't bind local rpctlssd socket"); 366b9cbc85dSRick Macklem } 367b9cbc85dSRick Macklem umask(oldmask); 368b9cbc85dSRick Macklem if (listen(fd, SOMAXCONN) < 0) { 369b9cbc85dSRick Macklem if (rpctls_debug_level == 0) { 370b9cbc85dSRick Macklem syslog(LOG_ERR, 371b9cbc85dSRick Macklem "Can't listen on local rpctlssd socket"); 372b9cbc85dSRick Macklem exit(1); 373b9cbc85dSRick Macklem } 374b9cbc85dSRick Macklem err(1, "Can't listen on local rpctlssd socket"); 375b9cbc85dSRick Macklem } 376b9cbc85dSRick Macklem xprt = svc_vc_create(fd, RPC_MAXDATASIZE, RPC_MAXDATASIZE); 377b9cbc85dSRick Macklem if (!xprt) { 378b9cbc85dSRick Macklem if (rpctls_debug_level == 0) { 379b9cbc85dSRick Macklem syslog(LOG_ERR, 380b9cbc85dSRick Macklem "Can't create transport for local rpctlssd socket"); 381b9cbc85dSRick Macklem exit(1); 382b9cbc85dSRick Macklem } 383b9cbc85dSRick Macklem err(1, "Can't create transport for local rpctlssd socket"); 384b9cbc85dSRick Macklem } 385b9cbc85dSRick Macklem if (!svc_reg(xprt, RPCTLSSD, RPCTLSSDVERS, rpctlssd_1, NULL)) { 386b9cbc85dSRick Macklem if (rpctls_debug_level == 0) { 387b9cbc85dSRick Macklem syslog(LOG_ERR, 388b9cbc85dSRick Macklem "Can't register service for local rpctlssd socket"); 389b9cbc85dSRick Macklem exit(1); 390b9cbc85dSRick Macklem } 391b9cbc85dSRick Macklem err(1, "Can't register service for local rpctlssd socket"); 392b9cbc85dSRick Macklem } 393b9cbc85dSRick Macklem 394b9cbc85dSRick Macklem rpctls_ctx = rpctls_setup_ssl(rpctls_certdir); 395b9cbc85dSRick Macklem if (rpctls_ctx == NULL) { 396b9cbc85dSRick Macklem if (rpctls_debug_level == 0) { 397b9cbc85dSRick Macklem syslog(LOG_ERR, "Can't create SSL context"); 398b9cbc85dSRick Macklem exit(1); 399b9cbc85dSRick Macklem } 400b9cbc85dSRick Macklem err(1, "Can't create SSL context"); 401b9cbc85dSRick Macklem } 402b9cbc85dSRick Macklem rpctls_gothup = false; 403b9cbc85dSRick Macklem LIST_INIT(&rpctls_ssllist); 404b9cbc85dSRick Macklem 405ab3c59a1SRick Macklem if (rpctls_syscall(RPCTLS_SYSC_SRVSETPATH, rpctls_sockname[mypos]) < 0){ 406ab3c59a1SRick Macklem if (rpctls_debug_level == 0) { 407ab3c59a1SRick Macklem syslog(LOG_ERR, 408ab3c59a1SRick Macklem "Can't set upcall socket path=%s errno=%d", 409ab3c59a1SRick Macklem rpctls_sockname[mypos], errno); 410ab3c59a1SRick Macklem exit(1); 411ab3c59a1SRick Macklem } 412ab3c59a1SRick Macklem err(1, "Can't set upcall socket path=%s", 413ab3c59a1SRick Macklem rpctls_sockname[mypos]); 414ab3c59a1SRick Macklem } 415b9cbc85dSRick Macklem 416b9cbc85dSRick Macklem rpctls_svc_run(); 417b9cbc85dSRick Macklem 418b9cbc85dSRick Macklem SSL_CTX_free(rpctls_ctx); 419b9cbc85dSRick Macklem EVP_cleanup(); 420b9cbc85dSRick Macklem return (0); 421b9cbc85dSRick Macklem } 422b9cbc85dSRick Macklem 423b9cbc85dSRick Macklem bool_t 424b9cbc85dSRick Macklem rpctlssd_null_1_svc(__unused void *argp, __unused void *result, 425b9cbc85dSRick Macklem __unused struct svc_req *rqstp) 426b9cbc85dSRick Macklem { 427b9cbc85dSRick Macklem 428b9cbc85dSRick Macklem rpctls_verbose_out("rpctlssd_null_svc: done\n"); 429b9cbc85dSRick Macklem return (TRUE); 430b9cbc85dSRick Macklem } 431b9cbc85dSRick Macklem 432b9cbc85dSRick Macklem bool_t 433b9cbc85dSRick Macklem rpctlssd_connect_1_svc(__unused void *argp, 434b9cbc85dSRick Macklem struct rpctlssd_connect_res *result, __unused struct svc_req *rqstp) 435b9cbc85dSRick Macklem { 436b9cbc85dSRick Macklem int ngrps, s; 437b9cbc85dSRick Macklem SSL *ssl; 438b9cbc85dSRick Macklem uint32_t flags; 439b9cbc85dSRick Macklem struct ssl_entry *newslp; 440b9cbc85dSRick Macklem uint32_t uid; 441b9cbc85dSRick Macklem uint32_t *gidp; 442b9cbc85dSRick Macklem X509 *cert; 443b9cbc85dSRick Macklem 444b9cbc85dSRick Macklem rpctls_verbose_out("rpctlsd_connect_svc: started\n"); 445b9cbc85dSRick Macklem memset(result, 0, sizeof(*result)); 446b9cbc85dSRick Macklem /* Get the socket fd from the kernel. */ 447b9cbc85dSRick Macklem s = rpctls_syscall(RPCTLS_SYSC_SRVSOCKET, ""); 448b9cbc85dSRick Macklem if (s < 0) 449b9cbc85dSRick Macklem return (FALSE); 450b9cbc85dSRick Macklem 451b9cbc85dSRick Macklem /* Do the server side of a TLS handshake. */ 452b9cbc85dSRick Macklem gidp = calloc(NGROUPS, sizeof(*gidp)); 453b9cbc85dSRick Macklem ssl = rpctls_server(rpctls_ctx, s, &flags, &uid, &ngrps, gidp, &cert); 454b9cbc85dSRick Macklem if (ssl == NULL) { 455b9cbc85dSRick Macklem free(gidp); 456b9cbc85dSRick Macklem rpctls_verbose_out("rpctlssd_connect_svc: ssl " 457b9cbc85dSRick Macklem "accept failed\n"); 458b9cbc85dSRick Macklem /* 459b9cbc85dSRick Macklem * For RPC-over-TLS, this upcall is expected 460b9cbc85dSRick Macklem * to close off the socket upon handshake failure. 461b9cbc85dSRick Macklem */ 462b9cbc85dSRick Macklem close(s); 463b9cbc85dSRick Macklem return (FALSE); 464b9cbc85dSRick Macklem } else { 465b9cbc85dSRick Macklem rpctls_verbose_out("rpctlssd_connect_svc: " 466b9cbc85dSRick Macklem "succeeded flags=0x%x\n", flags); 467b9cbc85dSRick Macklem result->flags = flags; 468b9cbc85dSRick Macklem result->sec = rpctls_ssl_sec; 469b9cbc85dSRick Macklem result->usec = rpctls_ssl_usec; 470b9cbc85dSRick Macklem result->ssl = ++rpctls_ssl_refno; 471b9cbc85dSRick Macklem /* Hard to believe this could ever wrap around.. */ 472b9cbc85dSRick Macklem if (rpctls_ssl_refno == 0) 473b9cbc85dSRick Macklem result->ssl = ++rpctls_ssl_refno; 474b9cbc85dSRick Macklem if ((flags & RPCTLS_FLAGS_CERTUSER) != 0) { 475b9cbc85dSRick Macklem result->uid = uid; 476b9cbc85dSRick Macklem result->gid.gid_len = ngrps; 477b9cbc85dSRick Macklem result->gid.gid_val = gidp; 478b9cbc85dSRick Macklem } else { 479b9cbc85dSRick Macklem result->uid = 0; 480b9cbc85dSRick Macklem result->gid.gid_len = 0; 481b9cbc85dSRick Macklem result->gid.gid_val = gidp; 482b9cbc85dSRick Macklem } 483b9cbc85dSRick Macklem } 484b9cbc85dSRick Macklem 485b9cbc85dSRick Macklem /* Maintain list of all current SSL *'s */ 486b9cbc85dSRick Macklem newslp = malloc(sizeof(*newslp)); 487b9cbc85dSRick Macklem newslp->ssl = ssl; 488b9cbc85dSRick Macklem newslp->s = s; 489b9cbc85dSRick Macklem newslp->shutoff = false; 490b9cbc85dSRick Macklem newslp->refno = rpctls_ssl_refno; 491b9cbc85dSRick Macklem newslp->cert = cert; 492b9cbc85dSRick Macklem LIST_INSERT_HEAD(&rpctls_ssllist, newslp, next); 493b9cbc85dSRick Macklem return (TRUE); 494b9cbc85dSRick Macklem } 495b9cbc85dSRick Macklem 496b9cbc85dSRick Macklem bool_t 497b9cbc85dSRick Macklem rpctlssd_handlerecord_1_svc(struct rpctlssd_handlerecord_arg *argp, 498b9cbc85dSRick Macklem struct rpctlssd_handlerecord_res *result, __unused struct svc_req *rqstp) 499b9cbc85dSRick Macklem { 500b9cbc85dSRick Macklem struct ssl_entry *slp; 501b9cbc85dSRick Macklem int ret; 502b9cbc85dSRick Macklem char junk; 503b9cbc85dSRick Macklem 504b9cbc85dSRick Macklem slp = NULL; 505b9cbc85dSRick Macklem if (argp->sec == rpctls_ssl_sec && argp->usec == 506b9cbc85dSRick Macklem rpctls_ssl_usec) { 507b9cbc85dSRick Macklem LIST_FOREACH(slp, &rpctls_ssllist, next) { 508b9cbc85dSRick Macklem if (slp->refno == argp->ssl) 509b9cbc85dSRick Macklem break; 510b9cbc85dSRick Macklem } 511b9cbc85dSRick Macklem } 512b9cbc85dSRick Macklem 513b9cbc85dSRick Macklem if (slp != NULL) { 514b9cbc85dSRick Macklem rpctls_verbose_out("rpctlssd_handlerecord fd=%d\n", 515b9cbc85dSRick Macklem slp->s); 516b9cbc85dSRick Macklem /* 517b9cbc85dSRick Macklem * An SSL_read() of 0 bytes should fail, but it should 518b9cbc85dSRick Macklem * handle the non-application data record before doing so. 519b9cbc85dSRick Macklem */ 520b9cbc85dSRick Macklem ret = SSL_read(slp->ssl, &junk, 0); 521b9cbc85dSRick Macklem if (ret <= 0) { 522b9cbc85dSRick Macklem /* Check to see if this was a close alert. */ 523b9cbc85dSRick Macklem ret = SSL_get_shutdown(slp->ssl); 524b9cbc85dSRick Macklem if ((ret & (SSL_SENT_SHUTDOWN | 525b9cbc85dSRick Macklem SSL_RECEIVED_SHUTDOWN)) == SSL_RECEIVED_SHUTDOWN) 526b9cbc85dSRick Macklem SSL_shutdown(slp->ssl); 527b9cbc85dSRick Macklem } else { 528b9cbc85dSRick Macklem if (rpctls_debug_level == 0) 529b9cbc85dSRick Macklem syslog(LOG_ERR, "SSL_read returned %d", ret); 530b9cbc85dSRick Macklem else 531b9cbc85dSRick Macklem fprintf(stderr, "SSL_read returned %d\n", ret); 532b9cbc85dSRick Macklem } 533b9cbc85dSRick Macklem result->reterr = RPCTLSERR_OK; 534b9cbc85dSRick Macklem } else 535b9cbc85dSRick Macklem result->reterr = RPCTLSERR_NOSSL; 536b9cbc85dSRick Macklem return (TRUE); 537b9cbc85dSRick Macklem } 538b9cbc85dSRick Macklem 539b9cbc85dSRick Macklem bool_t 540b9cbc85dSRick Macklem rpctlssd_disconnect_1_svc(struct rpctlssd_disconnect_arg *argp, 541b9cbc85dSRick Macklem struct rpctlssd_disconnect_res *result, __unused struct svc_req *rqstp) 542b9cbc85dSRick Macklem { 543b9cbc85dSRick Macklem struct ssl_entry *slp; 544b9cbc85dSRick Macklem int ret; 545b9cbc85dSRick Macklem 546b9cbc85dSRick Macklem slp = NULL; 547b9cbc85dSRick Macklem if (argp->sec == rpctls_ssl_sec && argp->usec == 548b9cbc85dSRick Macklem rpctls_ssl_usec) { 549b9cbc85dSRick Macklem LIST_FOREACH(slp, &rpctls_ssllist, next) { 550b9cbc85dSRick Macklem if (slp->refno == argp->ssl) 551b9cbc85dSRick Macklem break; 552b9cbc85dSRick Macklem } 553b9cbc85dSRick Macklem } 554b9cbc85dSRick Macklem 555b9cbc85dSRick Macklem if (slp != NULL) { 556b9cbc85dSRick Macklem rpctls_verbose_out("rpctlssd_disconnect fd=%d closed\n", 557b9cbc85dSRick Macklem slp->s); 558b9cbc85dSRick Macklem LIST_REMOVE(slp, next); 559b9cbc85dSRick Macklem if (!slp->shutoff) { 560b9cbc85dSRick Macklem ret = SSL_get_shutdown(slp->ssl); 561b9cbc85dSRick Macklem /* 562b9cbc85dSRick Macklem * Do an SSL_shutdown() unless a close alert has 563b9cbc85dSRick Macklem * already been sent. 564b9cbc85dSRick Macklem */ 565b9cbc85dSRick Macklem if ((ret & SSL_SENT_SHUTDOWN) == 0) 566b9cbc85dSRick Macklem SSL_shutdown(slp->ssl); 567b9cbc85dSRick Macklem } 568b9cbc85dSRick Macklem SSL_free(slp->ssl); 569b9cbc85dSRick Macklem if (slp->cert != NULL) 570b9cbc85dSRick Macklem X509_free(slp->cert); 571b9cbc85dSRick Macklem /* 572b9cbc85dSRick Macklem * For RPC-over-TLS, this upcall is expected 573b9cbc85dSRick Macklem * to close off the socket. 574b9cbc85dSRick Macklem */ 575b9cbc85dSRick Macklem if (!slp->shutoff) 576b9cbc85dSRick Macklem shutdown(slp->s, SHUT_WR); 577b9cbc85dSRick Macklem close(slp->s); 578b9cbc85dSRick Macklem free(slp); 579b9cbc85dSRick Macklem result->reterr = RPCTLSERR_OK; 580b9cbc85dSRick Macklem } else 581b9cbc85dSRick Macklem result->reterr = RPCTLSERR_NOCLOSE; 582b9cbc85dSRick Macklem return (TRUE); 583b9cbc85dSRick Macklem } 584b9cbc85dSRick Macklem 585b9cbc85dSRick Macklem int 586b9cbc85dSRick Macklem rpctlssd_1_freeresult(__unused SVCXPRT *transp, xdrproc_t xdr_result, 587b9cbc85dSRick Macklem caddr_t result) 588b9cbc85dSRick Macklem { 589b9cbc85dSRick Macklem rpctlssd_connect_res *res; 590b9cbc85dSRick Macklem 591b9cbc85dSRick Macklem if (xdr_result == (xdrproc_t)xdr_rpctlssd_connect_res) { 592b9cbc85dSRick Macklem res = (rpctlssd_connect_res *)(void *)result; 593b9cbc85dSRick Macklem free(res->gid.gid_val); 594b9cbc85dSRick Macklem } 595b9cbc85dSRick Macklem return (TRUE); 596b9cbc85dSRick Macklem } 597b9cbc85dSRick Macklem 5981e588a9cSRick Macklem /* 5991e588a9cSRick Macklem * cleanup_term() called via SIGTERM (or SIGCHLD if a child dies). 6001e588a9cSRick Macklem */ 601b9cbc85dSRick Macklem static void 6021e588a9cSRick Macklem rpctls_cleanup_term(int sig) 603b9cbc85dSRick Macklem { 604b9cbc85dSRick Macklem struct ssl_entry *slp; 6051e588a9cSRick Macklem int i, cnt; 6061e588a9cSRick Macklem 6071e588a9cSRick Macklem if (rpctls_im_a_worker && sig == SIGCHLD) 6081e588a9cSRick Macklem return; 6091e588a9cSRick Macklem LIST_FOREACH(slp, &rpctls_ssllist, next) 6101e588a9cSRick Macklem shutdown(slp->s, SHUT_RD); 6111e588a9cSRick Macklem SSL_CTX_free(rpctls_ctx); 6121e588a9cSRick Macklem EVP_cleanup(); 6131e588a9cSRick Macklem 6141e588a9cSRick Macklem if (rpctls_im_a_worker) 6151e588a9cSRick Macklem exit(0); 6161e588a9cSRick Macklem 6171e588a9cSRick Macklem /* I'm the server, so terminate the workers. */ 6181e588a9cSRick Macklem cnt = 0; 6191e588a9cSRick Macklem for (i = 0; i < rpctls_procs - 1; i++) { 6201e588a9cSRick Macklem if (rpctls_workers[i] != -1) { 6211e588a9cSRick Macklem cnt++; 6221e588a9cSRick Macklem kill(rpctls_workers[i], SIGTERM); 6231e588a9cSRick Macklem } 6241e588a9cSRick Macklem } 6251e588a9cSRick Macklem 6261e588a9cSRick Macklem /* 6271e588a9cSRick Macklem * Wait for them to die. 6281e588a9cSRick Macklem */ 6291e588a9cSRick Macklem for (i = 0; i < cnt; i++) 6301e588a9cSRick Macklem wait3(NULL, 0, NULL); 631b9cbc85dSRick Macklem 632b9cbc85dSRick Macklem rpctls_syscall(RPCTLS_SYSC_SRVSHUTDOWN, ""); 633b9cbc85dSRick Macklem pidfile_remove(rpctls_pfh); 634b9cbc85dSRick Macklem 635b9cbc85dSRick Macklem exit(0); 636b9cbc85dSRick Macklem } 637b9cbc85dSRick Macklem 638b9cbc85dSRick Macklem /* Allow the handshake to proceed. */ 639b9cbc85dSRick Macklem static int 640b9cbc85dSRick Macklem rpctls_verify_callback(__unused int preverify_ok, 641b9cbc85dSRick Macklem __unused X509_STORE_CTX *x509_ctx) 642b9cbc85dSRick Macklem { 643b9cbc85dSRick Macklem 644b9cbc85dSRick Macklem return (1); 645b9cbc85dSRick Macklem } 646b9cbc85dSRick Macklem 647b9cbc85dSRick Macklem static SSL_CTX * 648b9cbc85dSRick Macklem rpctls_setup_ssl(const char *certdir) 649b9cbc85dSRick Macklem { 650b9cbc85dSRick Macklem SSL_CTX *ctx; 651b9cbc85dSRick Macklem char path[PATH_MAX]; 652b9cbc85dSRick Macklem size_t len, rlen; 653b9cbc85dSRick Macklem int ret; 654b9cbc85dSRick Macklem 655b9cbc85dSRick Macklem SSL_library_init(); 656b9cbc85dSRick Macklem SSL_load_error_strings(); 657b9cbc85dSRick Macklem OpenSSL_add_all_algorithms(); 658b9cbc85dSRick Macklem 659b9cbc85dSRick Macklem ctx = SSL_CTX_new(TLS_server_method()); 660b9cbc85dSRick Macklem if (ctx == NULL) { 661b9cbc85dSRick Macklem rpctls_verbose_out("rpctls_setup_ssl: SSL_CTX_new failed\n"); 662b9cbc85dSRick Macklem return (NULL); 663b9cbc85dSRick Macklem } 664b9cbc85dSRick Macklem SSL_CTX_set_ecdh_auto(ctx, 1); 665b9cbc85dSRick Macklem 666712aac13SRick Macklem if (rpctls_ciphers != NULL) { 667b9cbc85dSRick Macklem /* 6688d098dedSRick Macklem * Set available ciphers, since KERN_TLS only supports a 669712aac13SRick Macklem * few of them. Normally, not doing this should be ok, 670712aac13SRick Macklem * since the library defaults will work. 671b9cbc85dSRick Macklem */ 6728d098dedSRick Macklem ret = SSL_CTX_set_ciphersuites(ctx, rpctls_ciphers); 673b9cbc85dSRick Macklem if (ret == 0) { 674b9cbc85dSRick Macklem rpctls_verbose_out("rpctls_setup_ssl: " 6758d098dedSRick Macklem "SSL_CTX_set_ciphersuites failed: %s\n", 676712aac13SRick Macklem rpctls_ciphers); 677b9cbc85dSRick Macklem SSL_CTX_free(ctx); 678b9cbc85dSRick Macklem return (NULL); 679b9cbc85dSRick Macklem } 680712aac13SRick Macklem } 681b9cbc85dSRick Macklem 6820637b12bSRick Macklem ret = SSL_CTX_set_min_proto_version(ctx, rpctls_mintls); 6830637b12bSRick Macklem if (ret == 0) { 6840637b12bSRick Macklem rpctls_verbose_out("rpctls_setup_ssl: " 6850637b12bSRick Macklem "SSL_CTX_set_min_proto_version failed\n"); 6860637b12bSRick Macklem SSL_CTX_free(ctx); 6870637b12bSRick Macklem return (NULL); 6880637b12bSRick Macklem } 6890637b12bSRick Macklem ret = SSL_CTX_set_max_proto_version(ctx, TLS1_3_VERSION); 6900637b12bSRick Macklem if (ret == 0) { 6910637b12bSRick Macklem rpctls_verbose_out("rpctls_setup_ssl: " 6920637b12bSRick Macklem "SSL_CTX_set_max_proto_version failed\n"); 6930637b12bSRick Macklem SSL_CTX_free(ctx); 6940637b12bSRick Macklem return (NULL); 6950637b12bSRick Macklem } 6960637b12bSRick Macklem 697b9cbc85dSRick Macklem /* Get the cert.pem and certkey.pem files from the directory certdir. */ 698b9cbc85dSRick Macklem len = strlcpy(path, certdir, sizeof(path)); 699b9cbc85dSRick Macklem rlen = sizeof(path) - len; 700b9cbc85dSRick Macklem if (strlcpy(&path[len], "cert.pem", rlen) != 8) { 701b9cbc85dSRick Macklem SSL_CTX_free(ctx); 702b9cbc85dSRick Macklem return (NULL); 703b9cbc85dSRick Macklem } 704b9cbc85dSRick Macklem ret = SSL_CTX_use_certificate_file(ctx, path, SSL_FILETYPE_PEM); 705b9cbc85dSRick Macklem if (ret != 1) { 706b9cbc85dSRick Macklem rpctls_verbose_out("rpctls_setup_ssl: can't use certificate " 707b9cbc85dSRick Macklem "file path=%s ret=%d\n", path, ret); 708b9cbc85dSRick Macklem SSL_CTX_free(ctx); 709b9cbc85dSRick Macklem return (NULL); 710b9cbc85dSRick Macklem } 711b9cbc85dSRick Macklem if (strlcpy(&path[len], "certkey.pem", rlen) != 11) { 712b9cbc85dSRick Macklem SSL_CTX_free(ctx); 713b9cbc85dSRick Macklem return (NULL); 714b9cbc85dSRick Macklem } 715b9cbc85dSRick Macklem ret = SSL_CTX_use_PrivateKey_file(ctx, path, SSL_FILETYPE_PEM); 716b9cbc85dSRick Macklem if (ret != 1) { 717b9cbc85dSRick Macklem rpctls_verbose_out("rpctls_setup_ssl: Can't use private " 718b9cbc85dSRick Macklem "key path=%s ret=%d\n", path, ret); 719b9cbc85dSRick Macklem SSL_CTX_free(ctx); 720b9cbc85dSRick Macklem return (NULL); 721b9cbc85dSRick Macklem } 722b9cbc85dSRick Macklem 723b9cbc85dSRick Macklem /* Set Mutual authentication, as required. */ 724b9cbc85dSRick Macklem if (rpctls_do_mutual) { 725b9cbc85dSRick Macklem if (rpctls_verify_cafile != NULL || 726b9cbc85dSRick Macklem rpctls_verify_capath != NULL) { 727b9cbc85dSRick Macklem if (rpctls_crlfile != NULL) { 728b9cbc85dSRick Macklem ret = rpctls_loadcrlfile(ctx); 729b9cbc85dSRick Macklem if (ret == 0) { 730b9cbc85dSRick Macklem rpctls_verbose_out("rpctls_setup_ssl:" 731b9cbc85dSRick Macklem " Load CRLfile failed\n"); 732b9cbc85dSRick Macklem SSL_CTX_free(ctx); 733b9cbc85dSRick Macklem return (NULL); 734b9cbc85dSRick Macklem } 735b9cbc85dSRick Macklem } 736b9cbc85dSRick Macklem #if OPENSSL_VERSION_NUMBER >= 0x30000000 737b9cbc85dSRick Macklem ret = 1; 738b9cbc85dSRick Macklem if (rpctls_verify_cafile != NULL) 739b9cbc85dSRick Macklem ret = SSL_CTX_load_verify_file(ctx, 740b9cbc85dSRick Macklem rpctls_verify_cafile); 741b9cbc85dSRick Macklem if (ret != 0 && rpctls_verify_capath != NULL) 742b9cbc85dSRick Macklem ret = SSL_CTX_load_verify_dir(ctx, 743b9cbc85dSRick Macklem rpctls_verify_capath); 744b9cbc85dSRick Macklem #else 745b9cbc85dSRick Macklem ret = SSL_CTX_load_verify_locations(ctx, 746b9cbc85dSRick Macklem rpctls_verify_cafile, rpctls_verify_capath); 747b9cbc85dSRick Macklem #endif 748b9cbc85dSRick Macklem if (ret == 0) { 749b9cbc85dSRick Macklem rpctls_verbose_out("rpctls_setup_ssl: " 750b9cbc85dSRick Macklem "Can't load verify locations\n"); 751b9cbc85dSRick Macklem SSL_CTX_free(ctx); 752b9cbc85dSRick Macklem return (NULL); 753b9cbc85dSRick Macklem } 754b9cbc85dSRick Macklem if (rpctls_verify_cafile != NULL) 755b9cbc85dSRick Macklem SSL_CTX_set_client_CA_list(ctx, 756b9cbc85dSRick Macklem SSL_load_client_CA_file( 757b9cbc85dSRick Macklem rpctls_verify_cafile)); 758b9cbc85dSRick Macklem } 759b9cbc85dSRick Macklem SSL_CTX_set_verify(ctx, SSL_VERIFY_PEER, 760b9cbc85dSRick Macklem rpctls_verify_callback); 761b9cbc85dSRick Macklem } 762c7bb0f47SJohn Baldwin #ifdef SSL_OP_ENABLE_KTLS 763c7bb0f47SJohn Baldwin SSL_CTX_set_options(ctx, SSL_OP_ENABLE_KTLS); 764c7bb0f47SJohn Baldwin #endif 765c7bb0f47SJohn Baldwin #ifdef SSL_MODE_NO_KTLS_TX 766b9cbc85dSRick Macklem SSL_CTX_clear_mode(ctx, SSL_MODE_NO_KTLS_TX | SSL_MODE_NO_KTLS_RX); 767c7bb0f47SJohn Baldwin #endif 768b9cbc85dSRick Macklem return (ctx); 769b9cbc85dSRick Macklem } 770b9cbc85dSRick Macklem 771b9cbc85dSRick Macklem static SSL * 772b9cbc85dSRick Macklem rpctls_server(SSL_CTX *ctx, int s, uint32_t *flags, uint32_t *uidp, 773b9cbc85dSRick Macklem int *ngrps, uint32_t *gidp, X509 **certp) 774b9cbc85dSRick Macklem { 775b9cbc85dSRick Macklem SSL *ssl; 776b9cbc85dSRick Macklem X509 *cert; 777b9cbc85dSRick Macklem struct sockaddr *sad; 778b9cbc85dSRick Macklem struct sockaddr_storage ad; 779b9cbc85dSRick Macklem char hostnam[NI_MAXHOST]; 780b9cbc85dSRick Macklem int gethostret, ret; 781b9cbc85dSRick Macklem char *cp, *cp2; 782b9cbc85dSRick Macklem long verfret; 783b9cbc85dSRick Macklem 784b9cbc85dSRick Macklem *flags = 0; 785b9cbc85dSRick Macklem *certp = NULL; 786b9cbc85dSRick Macklem sad = (struct sockaddr *)&ad; 787b9cbc85dSRick Macklem ssl = SSL_new(ctx); 788b9cbc85dSRick Macklem if (ssl == NULL) { 789b9cbc85dSRick Macklem rpctls_verbose_out("rpctls_server: SSL_new failed\n"); 790b9cbc85dSRick Macklem return (NULL); 791b9cbc85dSRick Macklem } 792b9cbc85dSRick Macklem if (SSL_set_fd(ssl, s) != 1) { 793b9cbc85dSRick Macklem rpctls_verbose_out("rpctls_server: SSL_set_fd failed\n"); 794b9cbc85dSRick Macklem SSL_free(ssl); 795b9cbc85dSRick Macklem return (NULL); 796b9cbc85dSRick Macklem } 797b9cbc85dSRick Macklem ret = SSL_accept(ssl); 798b9cbc85dSRick Macklem if (ret != 1) { 799b9cbc85dSRick Macklem rpctls_verbose_out("rpctls_server: SSL_accept " 800b9cbc85dSRick Macklem "failed ret=%d\n", ret); 801b9cbc85dSRick Macklem SSL_free(ssl); 802b9cbc85dSRick Macklem return (NULL); 803b9cbc85dSRick Macklem } 804b9cbc85dSRick Macklem *flags |= RPCTLS_FLAGS_HANDSHAKE; 805d71c9f14SRick Macklem if (rpctls_verbose) { 806d71c9f14SRick Macklem gethostret = rpctls_gethost(s, sad, hostnam, sizeof(hostnam)); 807d71c9f14SRick Macklem if (gethostret == 0) 808d71c9f14SRick Macklem hostnam[0] = '\0'; 809d71c9f14SRick Macklem rpctls_verbose_out("rpctls_server: SSL handshake ok for host %s" 810d71c9f14SRick Macklem " <%s %s>\n", hostnam, SSL_get_version(ssl), 811d71c9f14SRick Macklem SSL_get_cipher(ssl)); 812d71c9f14SRick Macklem } 813b9cbc85dSRick Macklem if (rpctls_do_mutual) { 814b9cbc85dSRick Macklem cert = SSL_get_peer_certificate(ssl); 815b9cbc85dSRick Macklem if (cert != NULL) { 816d71c9f14SRick Macklem if (!rpctls_verbose) { 817b9cbc85dSRick Macklem gethostret = rpctls_gethost(s, sad, hostnam, 818b9cbc85dSRick Macklem sizeof(hostnam)); 819b9cbc85dSRick Macklem if (gethostret == 0) 820b9cbc85dSRick Macklem hostnam[0] = '\0'; 821d71c9f14SRick Macklem } 822b9cbc85dSRick Macklem cp2 = X509_NAME_oneline( 823b9cbc85dSRick Macklem X509_get_subject_name(cert), NULL, 0); 824b9cbc85dSRick Macklem *flags |= RPCTLS_FLAGS_GOTCERT; 825b9cbc85dSRick Macklem verfret = SSL_get_verify_result(ssl); 826b9cbc85dSRick Macklem if (verfret != X509_V_OK) { 827b9cbc85dSRick Macklem cp = X509_NAME_oneline( 828b9cbc85dSRick Macklem X509_get_issuer_name(cert), NULL, 0); 829b9cbc85dSRick Macklem if (rpctls_debug_level == 0) 830b9cbc85dSRick Macklem syslog(LOG_INFO | LOG_DAEMON, 831b9cbc85dSRick Macklem "rpctls_server: client IP %s " 832b9cbc85dSRick Macklem "issuerName=%s subjectName=%s" 833b9cbc85dSRick Macklem " verify failed %s\n", hostnam, 834b9cbc85dSRick Macklem cp, cp2, 835b9cbc85dSRick Macklem X509_verify_cert_error_string( 836b9cbc85dSRick Macklem verfret)); 837b9cbc85dSRick Macklem else 838b9cbc85dSRick Macklem fprintf(stderr, 839b9cbc85dSRick Macklem "rpctls_server: client IP %s " 840b9cbc85dSRick Macklem "issuerName=%s subjectName=%s" 841b9cbc85dSRick Macklem " verify failed %s\n", hostnam, 842b9cbc85dSRick Macklem cp, cp2, 843b9cbc85dSRick Macklem X509_verify_cert_error_string( 844b9cbc85dSRick Macklem verfret)); 845b9cbc85dSRick Macklem } 846b9cbc85dSRick Macklem if (verfret == 847b9cbc85dSRick Macklem X509_V_ERR_DEPTH_ZERO_SELF_SIGNED_CERT || 848b9cbc85dSRick Macklem verfret == X509_V_ERR_SELF_SIGNED_CERT_IN_CHAIN) 849b9cbc85dSRick Macklem *flags |= RPCTLS_FLAGS_SELFSIGNED; 850b9cbc85dSRick Macklem else if (verfret == X509_V_OK) { 851b9cbc85dSRick Macklem if (rpctls_comparehost) { 852b9cbc85dSRick Macklem ret = 0; 853b9cbc85dSRick Macklem if (gethostret != 0) 854b9cbc85dSRick Macklem ret = rpctls_checkhost(sad, 855b9cbc85dSRick Macklem cert, rpctls_wildcard); 856b9cbc85dSRick Macklem if (ret != 1) { 857b9cbc85dSRick Macklem *flags |= 858b9cbc85dSRick Macklem RPCTLS_FLAGS_DISABLED; 859b9cbc85dSRick Macklem rpctls_verbose_out( 860b9cbc85dSRick Macklem "rpctls_server: " 861b9cbc85dSRick Macklem "checkhost " 862b9cbc85dSRick Macklem "failed\n"); 863b9cbc85dSRick Macklem } 864b9cbc85dSRick Macklem } 865b9cbc85dSRick Macklem if (rpctls_cnuser) { 866b9cbc85dSRick Macklem ret = rpctls_cnname(cert, uidp, 867b9cbc85dSRick Macklem ngrps, gidp); 868b9cbc85dSRick Macklem if (ret != 0) 869b9cbc85dSRick Macklem *flags |= RPCTLS_FLAGS_CERTUSER; 870b9cbc85dSRick Macklem } 871b9cbc85dSRick Macklem *flags |= RPCTLS_FLAGS_VERIFIED; 872b9cbc85dSRick Macklem *certp = cert; 873b9cbc85dSRick Macklem cert = NULL; 874b9cbc85dSRick Macklem } 875b9cbc85dSRick Macklem if (cert != NULL) 876b9cbc85dSRick Macklem X509_free(cert); 877b9cbc85dSRick Macklem } else 878b9cbc85dSRick Macklem rpctls_verbose_out("rpctls_server: " 879b9cbc85dSRick Macklem "No peer certificate\n"); 880b9cbc85dSRick Macklem } 881b9cbc85dSRick Macklem 882b9cbc85dSRick Macklem /* Check to see that ktls is working for the connection. */ 883b9cbc85dSRick Macklem ret = BIO_get_ktls_send(SSL_get_wbio(ssl)); 884b9cbc85dSRick Macklem rpctls_verbose_out("rpctls_server: BIO_get_ktls_send=%d\n", ret); 885b9cbc85dSRick Macklem if (ret != 0) { 886b9cbc85dSRick Macklem ret = BIO_get_ktls_recv(SSL_get_rbio(ssl)); 887b9cbc85dSRick Macklem rpctls_verbose_out("rpctls_server: BIO_get_ktls_recv=%d\n", 888b9cbc85dSRick Macklem ret); 889b9cbc85dSRick Macklem } 890b9cbc85dSRick Macklem if (ret == 0) { 891b9cbc85dSRick Macklem if (rpctls_debug_level == 0) 892b9cbc85dSRick Macklem syslog(LOG_ERR, "ktls not working"); 893b9cbc85dSRick Macklem else 894b9cbc85dSRick Macklem fprintf(stderr, "ktls not working\n"); 895b9cbc85dSRick Macklem /* 896b9cbc85dSRick Macklem * The handshake has completed, so all that can be 897b9cbc85dSRick Macklem * done is disable the connection. 898b9cbc85dSRick Macklem */ 899b9cbc85dSRick Macklem *flags |= RPCTLS_FLAGS_DISABLED; 900b9cbc85dSRick Macklem } 901b9cbc85dSRick Macklem 902b9cbc85dSRick Macklem return (ssl); 903b9cbc85dSRick Macklem } 904b9cbc85dSRick Macklem 905b9cbc85dSRick Macklem /* 906b9cbc85dSRick Macklem * Acquire the dnsname for this server. 907b9cbc85dSRick Macklem */ 908b9cbc85dSRick Macklem static char * 909b9cbc85dSRick Macklem rpctls_getdnsname(char *hostname) 910b9cbc85dSRick Macklem { 911b9cbc85dSRick Macklem char *cp, *dnsname; 912b9cbc85dSRick Macklem struct addrinfo *aip, hints; 913b9cbc85dSRick Macklem int error; 914b9cbc85dSRick Macklem 915b9cbc85dSRick Macklem dnsname = NULL; 916b9cbc85dSRick Macklem if (gethostname(hostname, MAXHOSTNAMELEN) == 0) { 917b9cbc85dSRick Macklem if ((cp = strchr(hostname, '.')) != NULL && 918b9cbc85dSRick Macklem *(cp + 1) != '\0') { 919b9cbc85dSRick Macklem *cp = '@'; 920b9cbc85dSRick Macklem dnsname = cp; 921b9cbc85dSRick Macklem } else { 922b9cbc85dSRick Macklem memset((void *)&hints, 0, sizeof (hints)); 923b9cbc85dSRick Macklem hints.ai_flags = AI_CANONNAME; 924b9cbc85dSRick Macklem error = getaddrinfo(hostname, NULL, &hints, &aip); 925b9cbc85dSRick Macklem if (error == 0) { 926b9cbc85dSRick Macklem if (aip->ai_canonname != NULL && 927b9cbc85dSRick Macklem (cp = strchr(aip->ai_canonname, '.')) != 928b9cbc85dSRick Macklem NULL && *(cp + 1) != '\0') { 929b9cbc85dSRick Macklem hostname[0] = '@'; 930b9cbc85dSRick Macklem strlcpy(&hostname[1], cp + 1, 931b9cbc85dSRick Macklem MAXHOSTNAMELEN + 1); 932b9cbc85dSRick Macklem dnsname = hostname; 933b9cbc85dSRick Macklem } 934b9cbc85dSRick Macklem freeaddrinfo(aip); 935b9cbc85dSRick Macklem } 936b9cbc85dSRick Macklem } 937b9cbc85dSRick Macklem } 938b9cbc85dSRick Macklem return (dnsname); 939b9cbc85dSRick Macklem } 940b9cbc85dSRick Macklem 941b9cbc85dSRick Macklem /* 942b9cbc85dSRick Macklem * Check for an otherName component of subjectAltName where the OID 943b9cbc85dSRick Macklem * matches and the "domain" matches that of this server. 944b9cbc85dSRick Macklem * If found, map "user" to a <uid, gidlist> for it. 945b9cbc85dSRick Macklem */ 946b9cbc85dSRick Macklem static int 947b9cbc85dSRick Macklem rpctls_cnname(X509 *cert, uint32_t *uidp, int *ngrps, uint32_t *gidp) 948b9cbc85dSRick Macklem { 949b9cbc85dSRick Macklem char *cp, usern[1024 + 1]; 950b9cbc85dSRick Macklem struct passwd *pwd; 951b9cbc85dSRick Macklem gid_t gids[NGROUPS]; 952b9cbc85dSRick Macklem int i, j; 953b9cbc85dSRick Macklem GENERAL_NAMES *genlist; 954b9cbc85dSRick Macklem GENERAL_NAME *genname; 955b9cbc85dSRick Macklem OTHERNAME *val; 956b9cbc85dSRick Macklem size_t slen; 957b9cbc85dSRick Macklem 958b9cbc85dSRick Macklem /* First, find the otherName in the subjectAltName. */ 959b9cbc85dSRick Macklem genlist = X509_get_ext_d2i(cert, NID_subject_alt_name, NULL, NULL); 960b9cbc85dSRick Macklem if (genlist == NULL) 961b9cbc85dSRick Macklem return (0); 962b9cbc85dSRick Macklem cp = NULL; 963b9cbc85dSRick Macklem for (i = 0; i < sk_GENERAL_NAME_num(genlist); i++) { 964b9cbc85dSRick Macklem genname = sk_GENERAL_NAME_value(genlist, i); 965b9cbc85dSRick Macklem if (genname->type != GEN_OTHERNAME) 966b9cbc85dSRick Macklem continue; 967b9cbc85dSRick Macklem val = genname->d.otherName; 968b9cbc85dSRick Macklem 969b9cbc85dSRick Macklem /* Check to see that it is the correct OID. */ 970b9cbc85dSRick Macklem slen = i2t_ASN1_OBJECT(usern, sizeof(usern), val->type_id); 971b9cbc85dSRick Macklem if (slen != strlen(rpctls_cnuseroid) || memcmp(usern, 972b9cbc85dSRick Macklem rpctls_cnuseroid, slen) != 0) 973b9cbc85dSRick Macklem continue; 974b9cbc85dSRick Macklem 975b9cbc85dSRick Macklem /* Sanity check the otherName. */ 976b9cbc85dSRick Macklem if (val->value->type != V_ASN1_UTF8STRING || 977b9cbc85dSRick Macklem val->value->value.utf8string->length < 3 || 978b9cbc85dSRick Macklem (size_t)val->value->value.utf8string->length > sizeof(usern) 979b9cbc85dSRick Macklem - 1) { 980b9cbc85dSRick Macklem rpctls_verbose_out("rpctls_cnname: invalid cnuser " 981b9cbc85dSRick Macklem "type=%d\n", val->value->type); 982b9cbc85dSRick Macklem continue; 983b9cbc85dSRick Macklem } 984b9cbc85dSRick Macklem 985b9cbc85dSRick Macklem /* Look for a "user" in the otherName */ 986b9cbc85dSRick Macklem memcpy(usern, val->value->value.utf8string->data, 987b9cbc85dSRick Macklem val->value->value.utf8string->length); 988b9cbc85dSRick Macklem usern[val->value->value.utf8string->length] = '\0'; 989b9cbc85dSRick Macklem 990b9cbc85dSRick Macklem /* Now, look for the @dnsname suffix in the commonName. */ 991b9cbc85dSRick Macklem cp = strcasestr(usern, rpctls_dnsname); 992b9cbc85dSRick Macklem if (cp == NULL) 993b9cbc85dSRick Macklem continue; 994b9cbc85dSRick Macklem if (*(cp + strlen(rpctls_dnsname)) != '\0') { 995b9cbc85dSRick Macklem cp = NULL; 996b9cbc85dSRick Macklem continue; 997b9cbc85dSRick Macklem } 998b9cbc85dSRick Macklem *cp = '\0'; 999b9cbc85dSRick Macklem break; 1000b9cbc85dSRick Macklem } 1001b9cbc85dSRick Macklem if (cp == NULL) 1002b9cbc85dSRick Macklem return (0); 1003b9cbc85dSRick Macklem 1004b9cbc85dSRick Macklem /* See if the "user" is in the passwd database. */ 1005b9cbc85dSRick Macklem pwd = getpwnam(usern); 1006b9cbc85dSRick Macklem if (pwd == NULL) 1007b9cbc85dSRick Macklem return (0); 1008b9cbc85dSRick Macklem *uidp = pwd->pw_uid; 1009b9cbc85dSRick Macklem *ngrps = NGROUPS; 1010b9cbc85dSRick Macklem if (getgrouplist(pwd->pw_name, pwd->pw_gid, gids, ngrps) < 0) 1011b9cbc85dSRick Macklem return (0); 1012b9cbc85dSRick Macklem rpctls_verbose_out("mapped user=%s ngrps=%d uid=%d\n", pwd->pw_name, 1013b9cbc85dSRick Macklem *ngrps, pwd->pw_uid); 1014b9cbc85dSRick Macklem for (j = 0; j < *ngrps; j++) 1015b9cbc85dSRick Macklem gidp[j] = gids[j]; 1016b9cbc85dSRick Macklem return (1); 1017b9cbc85dSRick Macklem } 1018b9cbc85dSRick Macklem 1019b9cbc85dSRick Macklem static void 1020b9cbc85dSRick Macklem rpctls_huphandler(int sig __unused) 1021b9cbc85dSRick Macklem { 1022b9cbc85dSRick Macklem 1023b9cbc85dSRick Macklem rpctls_gothup = true; 1024b9cbc85dSRick Macklem } 1025