s_client.c 117.3 KB
Newer Older
R
Rich Salz 已提交
1
/*
2
 * Copyright 1995-2019 The OpenSSL Project Authors. All Rights Reserved.
3
 * Copyright 2005 Nokia. All rights reserved.
4
 *
5
 * Licensed under the Apache License 2.0 (the "License").  You may not use
R
Rich Salz 已提交
6 7 8
 * this file except in compliance with the License.  You can obtain a copy
 * in the file LICENSE in the source distribution or at
 * https://www.openssl.org/source/license.html
9
 */
R
Rich Salz 已提交
10

11
#include "e_os.h"
12
#include <ctype.h>
U
Ulf Möller 已提交
13 14 15
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
V
Viktor Dukhovni 已提交
16
#include <errno.h>
17
#include <openssl/e_os2.h>
18

M
Matt Caswell 已提交
19 20
#ifndef OPENSSL_NO_SOCK

21 22 23 24 25 26
/*
 * With IPv6, it looks like Digital has mixed up the proper order of
 * recursive header file inclusion, resulting in the compiler complaining
 * that u_int isn't defined, but only if _POSIX_C_SOURCE is defined, which is
 * needed to have fileno() declared correctly...  So let's define u_int
 */
27
#if defined(OPENSSL_SYS_VMS_DECC) && !defined(__U_INT)
28
# define __U_INT
U
Ulf Möller 已提交
29 30 31
typedef unsigned int u_int;
#endif

32
#include "apps.h"
33
#include "progs.h"
34 35 36 37
#include <openssl/x509.h>
#include <openssl/ssl.h>
#include <openssl/err.h>
#include <openssl/pem.h>
38
#include <openssl/rand.h>
39
#include <openssl/ocsp.h>
40
#include <openssl/bn.h>
41
#include <openssl/trace.h>
M
Matt Caswell 已提交
42
#include <openssl/async.h>
B
Ben Laurie 已提交
43
#ifndef OPENSSL_NO_SRP
44
# include <openssl/srp.h>
B
Ben Laurie 已提交
45
#endif
46 47 48
#ifndef OPENSSL_NO_CT
# include <openssl/ct.h>
#endif
49
#include "s_apps.h"
B
Ben Laurie 已提交
50
#include "timeouts.h"
R
Rich Salz 已提交
51
#include "internal/sockets.h"
52

53 54 55 56 57 58
#if defined(__has_feature)
# if __has_feature(memory_sanitizer)
#  include <sanitizer/msan_interface.h>
# endif
#endif

59 60
#undef BUFSIZZ
#define BUFSIZZ 1024*8
61
#define S_CLIENT_IRC_READ_TIMEOUT 8
62

V
Viktor Dukhovni 已提交
63
static char *prog;
64
static int c_debug = 0;
65 66 67 68 69
static int c_showcerts = 0;
static char *keymatexportlabel = NULL;
static int keymatexportlen = 20;
static BIO *bio_c_out = NULL;
static int c_quiet = 0;
70
static char *sess_out = NULL;
71
static SSL_SESSION *psksess = NULL;
72

R
Rob Percival 已提交
73
static void print_stuff(BIO *berr, SSL *con, int full);
M
Matt Caswell 已提交
74
#ifndef OPENSSL_NO_OCSP
75
static int ocsp_resp_cb(SSL *s, void *arg);
M
Matt Caswell 已提交
76
#endif
77
static int ldap_ExtendedResponse_parse(const char *buf, long rem);
78
static char *base64encode (const void *buf, size_t len);
79
static int is_dNS_name(const char *host);
80

V
Viktor Dukhovni 已提交
81 82 83 84 85 86 87 88 89 90 91 92 93 94 95
static int saved_errno;

static void save_errno(void)
{
    saved_errno = errno;
    errno = 0;
}

static int restore_errno(void)
{
    int ret = errno;
    errno = saved_errno;
    return ret;
}

M
Matt Caswell 已提交
96 97 98 99 100 101 102 103 104 105 106 107
static void do_ssl_shutdown(SSL *ssl)
{
    int ret;

    do {
        /* We only do unidirectional shutdown */
        ret = SSL_shutdown(ssl);
        if (ret < 0) {
            switch (SSL_get_error(ssl, ret)) {
            case SSL_ERROR_WANT_READ:
            case SSL_ERROR_WANT_WRITE:
            case SSL_ERROR_WANT_ASYNC:
M
Matt Caswell 已提交
108
            case SSL_ERROR_WANT_ASYNC_JOB:
M
Matt Caswell 已提交
109 110 111 112 113 114 115 116
                /* We just do busy waiting. Nothing clever */
                continue;
            }
            ret = 0;
        }
    } while (ret < 0);
}

117
/* Default PSK identity and key */
118
static char *psk_identity = "Client_identity";
119

M
Matt Caswell 已提交
120
#ifndef OPENSSL_NO_PSK
121
static unsigned int psk_client_cb(SSL *ssl, const char *hint, char *identity,
122 123 124 125 126
                                  unsigned int max_identity_len,
                                  unsigned char *psk,
                                  unsigned int max_psk_len)
{
    int ret;
127 128
    long key_len;
    unsigned char *key;
129 130 131 132 133 134 135 136

    if (c_debug)
        BIO_printf(bio_c_out, "psk_client_cb\n");
    if (!hint) {
        /* no ServerKeyExchange message */
        if (c_debug)
            BIO_printf(bio_c_out,
                       "NULL received PSK identity hint, continuing anyway\n");
137
    } else if (c_debug) {
138
        BIO_printf(bio_c_out, "Received PSK identity hint '%s'\n", hint);
139
    }
140 141 142 143 144 145 146 147 148 149

    /*
     * lookup PSK identity and PSK key based on the given identity hint here
     */
    ret = BIO_snprintf(identity, max_identity_len, "%s", psk_identity);
    if (ret < 0 || (unsigned int)ret > max_identity_len)
        goto out_err;
    if (c_debug)
        BIO_printf(bio_c_out, "created identity '%s' len=%d\n", identity,
                   ret);
150 151 152 153 154

    /* convert the PSK key to binary */
    key = OPENSSL_hexstr2buf(psk_key, &key_len);
    if (key == NULL) {
        BIO_printf(bio_err, "Could not convert PSK key '%s' to buffer\n",
155 156 157
                   psk_key);
        return 0;
    }
B
Benjamin Kaduk 已提交
158
    if (max_psk_len > INT_MAX || key_len > (long)max_psk_len) {
159
        BIO_printf(bio_err,
160 161 162
                   "psk buffer of callback is too small (%d) for key (%ld)\n",
                   max_psk_len, key_len);
        OPENSSL_free(key);
163 164
        return 0;
    }
165

166 167
    memcpy(psk, key, key_len);
    OPENSSL_free(key);
168

169
    if (c_debug)
170
        BIO_printf(bio_c_out, "created PSK len=%ld\n", key_len);
171

172
    return key_len;
173
 out_err:
174 175 176 177
    if (c_debug)
        BIO_printf(bio_err, "Error in PSK client callback\n");
    return 0;
}
178 179
#endif

180 181
const unsigned char tls13_aes128gcmsha256_id[] = { 0x13, 0x01 };
const unsigned char tls13_aes256gcmsha384_id[] = { 0x13, 0x02 };
182

183 184 185 186
static int psk_use_session_cb(SSL *s, const EVP_MD *md,
                              const unsigned char **id, size_t *idlen,
                              SSL_SESSION **sess)
{
187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202
    SSL_SESSION *usesess = NULL;
    const SSL_CIPHER *cipher = NULL;

    if (psksess != NULL) {
        SSL_SESSION_up_ref(psksess);
        usesess = psksess;
    } else {
        long key_len;
        unsigned char *key = OPENSSL_hexstr2buf(psk_key, &key_len);

        if (key == NULL) {
            BIO_printf(bio_err, "Could not convert PSK key '%s' to buffer\n",
                       psk_key);
            return 0;
        }

203 204
        /* We default to SHA-256 */
        cipher = SSL_CIPHER_find(s, tls13_aes128gcmsha256_id);
205
        if (cipher == NULL) {
206
            BIO_printf(bio_err, "Error finding suitable ciphersuite\n");
207
            OPENSSL_free(key);
208
            return 0;
209
        }
210

211 212 213 214 215 216 217 218 219 220 221 222
        usesess = SSL_SESSION_new();
        if (usesess == NULL
                || !SSL_SESSION_set1_master_key(usesess, key, key_len)
                || !SSL_SESSION_set_cipher(usesess, cipher)
                || !SSL_SESSION_set_protocol_version(usesess, TLS1_3_VERSION)) {
            OPENSSL_free(key);
            goto err;
        }
        OPENSSL_free(key);
    }

    cipher = SSL_SESSION_get0_cipher(usesess);
223
    if (cipher == NULL)
224
        goto err;
225

226 227 228 229 230 231 232 233 234 235 236
    if (md != NULL && SSL_CIPHER_get_handshake_digest(cipher) != md) {
        /* PSK not usable, ignore it */
        *id = NULL;
        *idlen = 0;
        *sess = NULL;
        SSL_SESSION_free(usesess);
    } else {
        *sess = usesess;
        *id = (unsigned char *)psk_identity;
        *idlen = strlen(psk_identity);
    }
237 238

    return 1;
239 240 241 242

 err:
    SSL_SESSION_free(usesess);
    return 0;
243 244
}

245 246
/* This is a context that we pass to callbacks */
typedef struct tlsextctx_st {
247 248
    BIO *biodebug;
    int ack;
249 250
} tlsextctx;

R
Rich Salz 已提交
251
static int ssl_servername_cb(SSL *s, int *ad, void *arg)
252 253 254 255 256 257 258 259 260 261
{
    tlsextctx *p = (tlsextctx *) arg;
    const char *hn = SSL_get_servername(s, TLSEXT_NAMETYPE_host_name);
    if (SSL_get_servername_type(s) != -1)
        p->ack = !SSL_session_reused(s) && hn != NULL;
    else
        BIO_printf(bio_err, "Can't use SSL_get_servername\n");

    return SSL_TLSEXT_ERR_OK;
}
B
Ben Laurie 已提交
262

263
#ifndef OPENSSL_NO_SRP
B
Ben Laurie 已提交
264 265

/* This is a context that we pass to all callbacks */
266 267 268 269 270 271
typedef struct srp_arg_st {
    char *srppassin;
    char *srplogin;
    int msg;                    /* copy from c_msg */
    int debug;                  /* copy from c_debug */
    int amp;                    /* allow more groups */
272
    int strength;               /* minimal size for N */
273 274
} SRP_ARG;

275
# define SRP_NUMBER_ITERATIONS_FOR_PRIME 64
B
Ben Laurie 已提交
276

D
Dr. Stephen Henson 已提交
277
static int srp_Verify_N_and_g(const BIGNUM *N, const BIGNUM *g)
278 279 280 281 282 283
{
    BN_CTX *bn_ctx = BN_CTX_new();
    BIGNUM *p = BN_new();
    BIGNUM *r = BN_new();
    int ret =
        g != NULL && N != NULL && bn_ctx != NULL && BN_is_odd(N) &&
D
David Benjamin 已提交
284
        BN_is_prime_ex(N, SRP_NUMBER_ITERATIONS_FOR_PRIME, bn_ctx, NULL) == 1 &&
285 286
        p != NULL && BN_rshift1(p, N) &&
        /* p = (N-1)/2 */
D
David Benjamin 已提交
287
        BN_is_prime_ex(p, SRP_NUMBER_ITERATIONS_FOR_PRIME, bn_ctx, NULL) == 1 &&
288 289 290 291 292
        r != NULL &&
        /* verify g^((N-1)/2) == -1 (mod N) */
        BN_mod_exp(r, g, p, N, bn_ctx) &&
        BN_add_word(r, 1) && BN_cmp(r, N) == 0;

R
Rich Salz 已提交
293 294 295
    BN_free(r);
    BN_free(p);
    BN_CTX_free(bn_ctx);
296 297
    return ret;
}
B
Ben Laurie 已提交
298

299 300 301 302 303 304 305
/*-
 * This callback is used here for two purposes:
 * - extended debugging
 * - making some primality tests for unknown groups
 * The callback is only called for a non default group.
 *
 * An application does not need the call back at all if
306
 * only the standard groups are used.  In real life situations,
307 308
 * client and server already share well known groups,
 * thus there is no need to verify them.
309
 * Furthermore, in case that a server actually proposes a group that
310 311
 * is not one of those defined in RFC 5054, it is more appropriate
 * to add the group to a static list and then compare since
312 313
 * primality tests are rather cpu consuming.
 */
D
Dr. Stephen Henson 已提交
314

R
Rich Salz 已提交
315
static int ssl_srp_verify_param_cb(SSL *s, void *arg)
316 317 318
{
    SRP_ARG *srp_arg = (SRP_ARG *)arg;
    BIGNUM *N = NULL, *g = NULL;
319 320

    if (((N = SSL_get_srp_N(s)) == NULL) || ((g = SSL_get_srp_g(s)) == NULL))
321 322 323 324 325 326 327 328 329 330 331 332 333 334 335 336 337 338 339 340 341 342 343 344 345 346 347 348 349
        return 0;
    if (srp_arg->debug || srp_arg->msg || srp_arg->amp == 1) {
        BIO_printf(bio_err, "SRP parameters:\n");
        BIO_printf(bio_err, "\tN=");
        BN_print(bio_err, N);
        BIO_printf(bio_err, "\n\tg=");
        BN_print(bio_err, g);
        BIO_printf(bio_err, "\n");
    }

    if (SRP_check_known_gN_param(g, N))
        return 1;

    if (srp_arg->amp == 1) {
        if (srp_arg->debug)
            BIO_printf(bio_err,
                       "SRP param N and g are not known params, going to check deeper.\n");

        /*
         * The srp_moregroups is a real debugging feature. Implementors
         * should rather add the value to the known ones. The minimal size
         * has already been tested.
         */
        if (BN_num_bits(g) <= BN_BITS && srp_Verify_N_and_g(N, g))
            return 1;
    }
    BIO_printf(bio_err, "SRP param N and g rejected.\n");
    return 0;
}
B
Ben Laurie 已提交
350

351
# define PWD_STRLEN 1024
352 353 354 355

static char *ssl_give_srp_client_pwd_cb(SSL *s, void *arg)
{
    SRP_ARG *srp_arg = (SRP_ARG *)arg;
R
Rich Salz 已提交
356
    char *pass = app_malloc(PWD_STRLEN + 1, "SRP password buffer");
357 358 359 360 361 362 363 364 365 366 367 368 369 370 371
    PW_CB_DATA cb_tmp;
    int l;

    cb_tmp.password = (char *)srp_arg->srppassin;
    cb_tmp.prompt_info = "SRP user";
    if ((l = password_callback(pass, PWD_STRLEN, 0, &cb_tmp)) < 0) {
        BIO_printf(bio_err, "Can't read Password\n");
        OPENSSL_free(pass);
        return NULL;
    }
    *(pass + l) = '\0';

    return pass;
}

372
#endif
373

374
#ifndef OPENSSL_NO_NEXTPROTONEG
B
Ben Laurie 已提交
375 376
/* This the context that we pass to next_proto_cb */
typedef struct tlsextnextprotoctx_st {
377
    unsigned char *data;
T
Todd Short 已提交
378
    size_t len;
379
    int status;
B
Ben Laurie 已提交
380 381 382 383
} tlsextnextprotoctx;

static tlsextnextprotoctx next_proto;

384 385 386 387 388 389 390 391 392 393 394 395 396 397 398 399 400 401 402 403 404 405 406
static int next_proto_cb(SSL *s, unsigned char **out, unsigned char *outlen,
                         const unsigned char *in, unsigned int inlen,
                         void *arg)
{
    tlsextnextprotoctx *ctx = arg;

    if (!c_quiet) {
        /* We can assume that |in| is syntactically valid. */
        unsigned i;
        BIO_printf(bio_c_out, "Protocols advertised by server: ");
        for (i = 0; i < inlen;) {
            if (i)
                BIO_write(bio_c_out, ", ", 2);
            BIO_write(bio_c_out, &in[i + 1], in[i]);
            i += in[i] + 1;
        }
        BIO_write(bio_c_out, "\n", 1);
    }

    ctx->status =
        SSL_select_next_proto(out, outlen, in, inlen, ctx->data, ctx->len);
    return SSL_TLSEXT_ERR_OK;
}
407
#endif                         /* ndef OPENSSL_NO_NEXTPROTONEG */
408 409 410 411

static int serverinfo_cli_parse_cb(SSL *s, unsigned int ext_type,
                                   const unsigned char *in, size_t inlen,
                                   int *al, void *arg)
412
{
413 414 415 416
    char pem_name[100];
    unsigned char ext_buf[4 + 65536];

    /* Reconstruct the type/len fields prior to extension data */
417 418 419 420 421
    inlen &= 0xffff; /* for formal memcmpy correctness */
    ext_buf[0] = (unsigned char)(ext_type >> 8);
    ext_buf[1] = (unsigned char)(ext_type);
    ext_buf[2] = (unsigned char)(inlen >> 8);
    ext_buf[3] = (unsigned char)(inlen);
422 423 424 425 426 427 428 429
    memcpy(ext_buf + 4, in, inlen);

    BIO_snprintf(pem_name, sizeof(pem_name), "SERVERINFO FOR EXTENSION %d",
                 ext_type);
    PEM_write_bio(bio_c_out, pem_name, "", ext_buf, 4 + inlen);
    return 1;
}

V
Viktor Dukhovni 已提交
430 431 432 433 434 435 436 437
/*
 * Hex decoder that tolerates optional whitespace.  Returns number of bytes
 * produced, advances inptr to end of input string.
 */
static ossl_ssize_t hexdecode(const char **inptr, void *result)
{
    unsigned char **out = (unsigned char **)result;
    const char *in = *inptr;
F
FdaSilvaYY 已提交
438
    unsigned char *ret = app_malloc(strlen(in) / 2, "hexdecode");
V
Viktor Dukhovni 已提交
439 440 441 442 443 444 445 446
    unsigned char *cp = ret;
    uint8_t byte;
    int nibble = 0;

    if (ret == NULL)
        return -1;

    for (byte = 0; *in; ++in) {
R
Rich Salz 已提交
447
        int x;
V
Viktor Dukhovni 已提交
448

449
        if (isspace(_UC(*in)))
V
Viktor Dukhovni 已提交
450
            continue;
R
Rich Salz 已提交
451 452
        x = OPENSSL_hexchar2int(*in);
        if (x < 0) {
V
Viktor Dukhovni 已提交
453 454 455
            OPENSSL_free(ret);
            return 0;
        }
R
Rich Salz 已提交
456
        byte |= (char)x;
V
Viktor Dukhovni 已提交
457 458 459 460 461 462 463 464 465 466 467 468 469 470 471 472 473 474 475 476 477 478 479 480 481 482 483 484 485 486 487 488 489
        if ((nibble ^= 1) == 0) {
            *cp++ = byte;
            byte = 0;
        } else {
            byte <<= 4;
        }
    }
    if (nibble != 0) {
        OPENSSL_free(ret);
        return 0;
    }
    *inptr = in;

    return cp - (*out = ret);
}

/*
 * Decode unsigned 0..255, returns 1 on success, <= 0 on failure. Advances
 * inptr to next field skipping leading whitespace.
 */
static ossl_ssize_t checked_uint8(const char **inptr, void *out)
{
    uint8_t *result = (uint8_t *)out;
    const char *in = *inptr;
    char *endp;
    long v;
    int e;

    save_errno();
    v = strtol(in, &endp, 10);
    e = restore_errno();

    if (((v == LONG_MIN || v == LONG_MAX) && e == ERANGE) ||
490
        endp == in || !isspace(_UC(*endp)) ||
V
Viktor Dukhovni 已提交
491 492 493
        v != (*result = (uint8_t) v)) {
        return -1;
    }
494
    for (in = endp; isspace(_UC(*in)); ++in)
V
Viktor Dukhovni 已提交
495 496 497 498 499 500
        continue;

    *inptr = in;
    return 1;
}

R
Rich Salz 已提交
501 502 503 504 505 506
struct tlsa_field {
    void *var;
    const char *name;
    ossl_ssize_t (*parser)(const char **, void *);
};

V
Viktor Dukhovni 已提交
507 508
static int tlsa_import_rr(SSL *con, const char *rrdata)
{
R
Rich Salz 已提交
509 510 511 512 513
    /* Not necessary to re-init these values; the "parsers" do that. */
    static uint8_t usage;
    static uint8_t selector;
    static uint8_t mtype;
    static unsigned char *data;
R
Rich Salz 已提交
514
    static struct tlsa_field tlsa_fields[] = {
V
Viktor Dukhovni 已提交
515 516 517 518 519 520 521
        { &usage, "usage", checked_uint8 },
        { &selector, "selector", checked_uint8 },
        { &mtype, "mtype", checked_uint8 },
        { &data, "data", hexdecode },
        { NULL, }
    };
    struct tlsa_field *f;
R
Rich Salz 已提交
522 523 524
    int ret;
    const char *cp = rrdata;
    ossl_ssize_t len = 0;
V
Viktor Dukhovni 已提交
525 526 527 528 529 530 531 532 533 534 535 536 537 538 539 540 541 542 543 544 545 546 547 548 549 550 551 552 553 554 555 556 557 558 559 560 561 562 563 564 565 566

    for (f = tlsa_fields; f->var; ++f) {
        /* Returns number of bytes produced, advances cp to next field */
        if ((len = f->parser(&cp, f->var)) <= 0) {
            BIO_printf(bio_err, "%s: warning: bad TLSA %s field in: %s\n",
                       prog, f->name, rrdata);
            return 0;
        }
    }
    /* The data field is last, so len is its length */
    ret = SSL_dane_tlsa_add(con, usage, selector, mtype, data, len);
    OPENSSL_free(data);

    if (ret == 0) {
        ERR_print_errors(bio_err);
        BIO_printf(bio_err, "%s: warning: unusable TLSA rrdata: %s\n",
                   prog, rrdata);
        return 0;
    }
    if (ret < 0) {
        ERR_print_errors(bio_err);
        BIO_printf(bio_err, "%s: warning: error loading TLSA rrdata: %s\n",
                   prog, rrdata);
        return 0;
    }
    return ret;
}

static int tlsa_import_rrset(SSL *con, STACK_OF(OPENSSL_STRING) *rrset)
{
    int num = sk_OPENSSL_STRING_num(rrset);
    int count = 0;
    int i;

    for (i = 0; i < num; ++i) {
        char *rrdata = sk_OPENSSL_STRING_value(rrset, i);
        if (tlsa_import_rr(con, rrdata) > 0)
            ++count;
    }
    return count > 0;
}

567 568
typedef enum OPTION_choice {
    OPT_ERR = -1, OPT_EOF = 0, OPT_HELP,
569
    OPT_4, OPT_6, OPT_HOST, OPT_PORT, OPT_CONNECT, OPT_BIND, OPT_UNIX,
570
    OPT_XMPPHOST, OPT_VERIFY, OPT_NAMEOPT,
571 572 573
    OPT_CERT, OPT_CRL, OPT_CRL_DOWNLOAD, OPT_SESS_OUT, OPT_SESS_IN,
    OPT_CERTFORM, OPT_CRLFORM, OPT_VERIFY_RET_ERROR, OPT_VERIFY_QUIET,
    OPT_BRIEF, OPT_PREXIT, OPT_CRLF, OPT_QUIET, OPT_NBIO,
R
Rich Salz 已提交
574
    OPT_SSL_CLIENT_ENGINE, OPT_IGN_EOF, OPT_NO_IGN_EOF,
R
Rich Salz 已提交
575
    OPT_DEBUG, OPT_TLSEXTDEBUG, OPT_STATUS, OPT_WDEBUG,
576 577
    OPT_MSG, OPT_MSGFILE, OPT_ENGINE, OPT_TRACE, OPT_SECURITY_DEBUG,
    OPT_SECURITY_DEBUG_VERBOSE, OPT_SHOWCERTS, OPT_NBIO_TEST, OPT_STATE,
578
    OPT_PSK_IDENTITY, OPT_PSK, OPT_PSK_SESS,
579 580 581 582 583
#ifndef OPENSSL_NO_SRP
    OPT_SRPUSER, OPT_SRPPASS, OPT_SRP_STRENGTH, OPT_SRP_LATEUSER,
    OPT_SRP_MOREGROUPS,
#endif
    OPT_SSL3, OPT_SSL_CONFIG,
584
    OPT_TLS1_3, OPT_TLS1_2, OPT_TLS1_1, OPT_TLS1, OPT_DTLS, OPT_DTLS1,
M
Matt Caswell 已提交
585
    OPT_DTLS1_2, OPT_SCTP, OPT_TIMEOUT, OPT_MTU, OPT_KEYFORM, OPT_PASS,
586
    OPT_CERT_CHAIN, OPT_CAPATH, OPT_NOCAPATH, OPT_CHAINCAPATH, OPT_VERIFYCAPATH,
587
    OPT_KEY, OPT_RECONNECT, OPT_BUILD_CHAIN, OPT_CAFILE, OPT_NOCAFILE,
588
    OPT_CHAINCAFILE, OPT_VERIFYCAFILE, OPT_NEXTPROTONEG, OPT_ALPN,
589
    OPT_SERVERINFO, OPT_STARTTLS, OPT_SERVERNAME, OPT_NOSERVERNAME, OPT_ASYNC,
590
    OPT_USE_SRTP, OPT_KEYMATEXPORT, OPT_KEYMATEXPORTLEN, OPT_PROTOHOST,
591 592
    OPT_MAXFRAGLEN, OPT_MAX_SEND_FRAG, OPT_SPLIT_SEND_FRAG, OPT_MAX_PIPELINES,
    OPT_READ_BUF, OPT_KEYLOG_FILE, OPT_EARLY_DATA, OPT_REQCAFILE,
593 594 595
    OPT_V_ENUM,
    OPT_X_ENUM,
    OPT_S_ENUM,
596 597
    OPT_FALLBACKSCSV, OPT_NOCMDS, OPT_PROXY, OPT_PROXY_USER, OPT_PROXY_PASS,
    OPT_DANE_TLSA_DOMAIN,
598
#ifndef OPENSSL_NO_CT
599
    OPT_CT, OPT_NOCT, OPT_CTLOG_FILE,
600
#endif
R
Rich Salz 已提交
601
    OPT_DANE_TLSA_RRDATA, OPT_DANE_EE_NO_NAME,
602
    OPT_ENABLE_PHA,
603
    OPT_SCTP_LABEL_BUG,
R
Rich Salz 已提交
604
    OPT_R_ENUM
605 606
} OPTION_CHOICE;

F
FdaSilvaYY 已提交
607
const OPTIONS s_client_options[] = {
608 609 610 611
    {"help", OPT_HELP, '-', "Display this summary"},
    {"host", OPT_HOST, 's', "Use -connect instead"},
    {"port", OPT_PORT, 'p', "Use -connect instead"},
    {"connect", OPT_CONNECT, 's',
612
     "TCP/IP where to connect (default is :" PORT ")"},
613
    {"bind", OPT_BIND, 's', "bind local address for connection"},
614 615
    {"proxy", OPT_PROXY, 's',
     "Connect to via specified proxy to the real server"},
616 617
    {"proxy_user", OPT_PROXY_USER, 's', "UserID for proxy authentication"},
    {"proxy_pass", OPT_PROXY_PASS, 's', "Proxy authentication password source"},
618
#ifdef AF_UNIX
619
    {"unix", OPT_UNIX, 's', "Connect over the specified Unix-domain socket"},
620 621
#endif
    {"4", OPT_4, '-', "Use IPv4 only"},
622
#ifdef AF_INET6
623
    {"6", OPT_6, '-', "Use IPv6 only"},
624
#endif
625 626 627 628
    {"verify", OPT_VERIFY, 'p', "Turn on peer certificate verification"},
    {"cert", OPT_CERT, '<', "Certificate file to use, PEM format assumed"},
    {"certform", OPT_CERTFORM, 'F',
     "Certificate format (PEM or DER) PEM default"},
629
    {"nameopt", OPT_NAMEOPT, 's', "Various certificate name options"},
630 631
    {"key", OPT_KEY, 's', "Private key file to use, if not in -cert file"},
    {"keyform", OPT_KEYFORM, 'E', "Key format (PEM, DER or engine) PEM default"},
632 633 634
    {"pass", OPT_PASS, 's', "Private key file pass phrase source"},
    {"CApath", OPT_CAPATH, '/', "PEM format directory of CA's"},
    {"CAfile", OPT_CAFILE, '<', "PEM format file of CA's"},
635 636 637 638
    {"no-CAfile", OPT_NOCAFILE, '-',
     "Do not load the default certificates file"},
    {"no-CApath", OPT_NOCAPATH, '-',
     "Do not load certificates from the default certificates directory"},
D
Dr. Stephen Henson 已提交
639
    {"requestCAfile", OPT_REQCAFILE, '<',
640
      "PEM format file of CA names to send to the server"},
V
Viktor Dukhovni 已提交
641 642 643
    {"dane_tlsa_domain", OPT_DANE_TLSA_DOMAIN, 's', "DANE TLSA base domain"},
    {"dane_tlsa_rrdata", OPT_DANE_TLSA_RRDATA, 's',
     "DANE TLSA rrdata presentation form"},
644 645
    {"dane_ee_no_namechecks", OPT_DANE_EE_NO_NAME, '-',
     "Disable name checks when matching DANE-EE(3) TLSA records"},
646 647
    {"reconnect", OPT_RECONNECT, '-',
     "Drop and re-make the connection with the same Session-ID"},
648 649
    {"showcerts", OPT_SHOWCERTS, '-',
     "Show all certificates sent by the server"},
650 651
    {"debug", OPT_DEBUG, '-', "Extra output"},
    {"msg", OPT_MSG, '-', "Show protocol messages"},
R
Rich Salz 已提交
652 653
    {"msgfile", OPT_MSGFILE, '>',
     "File to send output of -msg or -trace, instead of stdout"},
654 655 656 657 658 659 660
    {"nbio_test", OPT_NBIO_TEST, '-', "More ssl protocol testing"},
    {"state", OPT_STATE, '-', "Print the ssl states"},
    {"crlf", OPT_CRLF, '-', "Convert LF from terminal into CRLF"},
    {"quiet", OPT_QUIET, '-', "No s_client output"},
    {"ign_eof", OPT_IGN_EOF, '-', "Ignore input eof (default when -quiet)"},
    {"no_ign_eof", OPT_NO_IGN_EOF, '-', "Don't ignore input eof"},
    {"starttls", OPT_STARTTLS, 's',
661
     "Use the appropriate STARTTLS command before starting TLS"},
662
    {"xmpphost", OPT_XMPPHOST, 's',
663
     "Alias of -name option for \"-starttls xmpp[-server]\""},
R
Rich Salz 已提交
664
    OPT_R_OPTIONS,
665 666
    {"sess_out", OPT_SESS_OUT, '>', "File to write SSL session to"},
    {"sess_in", OPT_SESS_IN, '<', "File to read SSL session from"},
667
#ifndef OPENSSL_NO_SRTP
668
    {"use_srtp", OPT_USE_SRTP, 's',
669
     "Offer SRTP key management with a colon-separated profile list"},
670
#endif
671 672 673 674
    {"keymatexport", OPT_KEYMATEXPORT, 's',
     "Export keying material using label"},
    {"keymatexportlen", OPT_KEYMATEXPORTLEN, 'p',
     "Export len bytes of keying material (default 20)"},
675 676
    {"maxfraglen", OPT_MAXFRAGLEN, 'p',
     "Enable Maximum Fragment Length Negotiation (len values: 512, 1024, 2048 and 4096)"},
677
    {"fallback_scsv", OPT_FALLBACKSCSV, '-', "Send the fallback SCSV"},
678 679
    {"name", OPT_PROTOHOST, 's',
     "Hostname to use for \"-starttls lmtp\", \"-starttls smtp\" or \"-starttls xmpp[-server]\""},
R
Rich Salz 已提交
680 681 682 683 684 685 686 687 688 689 690 691 692 693 694 695 696 697 698 699 700 701 702 703 704
    {"CRL", OPT_CRL, '<', "CRL file to use"},
    {"crl_download", OPT_CRL_DOWNLOAD, '-', "Download CRL from distribution points"},
    {"CRLform", OPT_CRLFORM, 'F', "CRL format (PEM or DER) PEM is default"},
    {"verify_return_error", OPT_VERIFY_RET_ERROR, '-',
     "Close connection on verification error"},
    {"verify_quiet", OPT_VERIFY_QUIET, '-', "Restrict verify output to errors"},
    {"brief", OPT_BRIEF, '-',
     "Restrict output to brief summary of connection parameters"},
    {"prexit", OPT_PREXIT, '-',
     "Print session information when the program exits"},
    {"security_debug", OPT_SECURITY_DEBUG, '-',
     "Enable security debug messages"},
    {"security_debug_verbose", OPT_SECURITY_DEBUG_VERBOSE, '-',
     "Output more security debug output"},
    {"cert_chain", OPT_CERT_CHAIN, '<',
     "Certificate chain file (in PEM format)"},
    {"chainCApath", OPT_CHAINCAPATH, '/',
     "Use dir as certificate store path to build CA certificate chain"},
    {"verifyCApath", OPT_VERIFYCAPATH, '/',
     "Use dir as certificate store path to verify CA certificate"},
    {"build_chain", OPT_BUILD_CHAIN, '-', "Build certificate chain"},
    {"chainCAfile", OPT_CHAINCAFILE, '<',
     "CA file for certificate chain (PEM format)"},
    {"verifyCAfile", OPT_VERIFYCAFILE, '<',
     "CA file for certificate verification (PEM format)"},
705 706
    {"nocommands", OPT_NOCMDS, '-', "Do not use interactive command letters"},
    {"servername", OPT_SERVERNAME, 's',
707
     "Set TLS extension servername (SNI) in ClientHello (default)"},
708 709
    {"noservername", OPT_NOSERVERNAME, '-',
     "Do not send the server name (SNI) extension in the ClientHello"},
710 711
    {"tlsextdebug", OPT_TLSEXTDEBUG, '-',
     "Hex dump of all TLS extensions received"},
M
Matt Caswell 已提交
712
#ifndef OPENSSL_NO_OCSP
713
    {"status", OPT_STATUS, '-', "Request certificate status from server"},
M
Matt Caswell 已提交
714
#endif
715 716 717 718
    {"serverinfo", OPT_SERVERINFO, 's',
     "types  Send empty ClientHello extensions (comma-separated numbers)"},
    {"alpn", OPT_ALPN, 's',
     "Enable ALPN extension, considering named protocols supported (comma-separated list)"},
719
    {"async", OPT_ASYNC, '-', "Support asynchronous operation"},
R
Rich Salz 已提交
720
    {"ssl_config", OPT_SSL_CONFIG, 's', "Use specified configuration file"},
721
    {"max_send_frag", OPT_MAX_SEND_FRAG, 'p', "Maximum Size of send frames "},
722
    {"split_send_frag", OPT_SPLIT_SEND_FRAG, 'p',
723
     "Size used to split data for encrypt pipelines"},
724
    {"max_pipelines", OPT_MAX_PIPELINES, 'p',
725
     "Maximum number of encrypt/decrypt pipelines to be used"},
726
    {"read_buf", OPT_READ_BUF, 'p',
727
     "Default read buffer size to be used for connections"},
728 729 730 731 732 733
    OPT_S_OPTIONS,
    OPT_V_OPTIONS,
    OPT_X_OPTIONS,
#ifndef OPENSSL_NO_SSL3
    {"ssl3", OPT_SSL3, '-', "Just use SSLv3"},
#endif
734 735 736 737 738 739 740 741 742
#ifndef OPENSSL_NO_TLS1
    {"tls1", OPT_TLS1, '-', "Just use TLSv1"},
#endif
#ifndef OPENSSL_NO_TLS1_1
    {"tls1_1", OPT_TLS1_1, '-', "Just use TLSv1.1"},
#endif
#ifndef OPENSSL_NO_TLS1_2
    {"tls1_2", OPT_TLS1_2, '-', "Just use TLSv1.2"},
#endif
743 744 745
#ifndef OPENSSL_NO_TLS1_3
    {"tls1_3", OPT_TLS1_3, '-', "Just use TLSv1.3"},
#endif
746
#ifndef OPENSSL_NO_DTLS
R
Rich Salz 已提交
747 748 749
    {"dtls", OPT_DTLS, '-', "Use any version of DTLS"},
    {"timeout", OPT_TIMEOUT, '-',
     "Enable send/receive timeout on DTLS connections"},
750 751
    {"mtu", OPT_MTU, 'p', "Set the link layer MTU"},
#endif
752 753 754 755
#ifndef OPENSSL_NO_DTLS1
    {"dtls1", OPT_DTLS1, '-', "Just use DTLSv1"},
#endif
#ifndef OPENSSL_NO_DTLS1_2
R
Rich Salz 已提交
756
    {"dtls1_2", OPT_DTLS1_2, '-', "Just use DTLSv1.2"},
757
#endif
M
Matt Caswell 已提交
758 759
#ifndef OPENSSL_NO_SCTP
    {"sctp", OPT_SCTP, '-', "Use SCTP"},
760
    {"sctp_label_bug", OPT_SCTP_LABEL_BUG, '-', "Enable SCTP label length bug"},
M
Matt Caswell 已提交
761
#endif
762
#ifndef OPENSSL_NO_SSL_TRACE
R
Rich Salz 已提交
763
    {"trace", OPT_TRACE, '-', "Show trace output of protocol messages"},
764
#endif
765 766 767 768 769 770
#ifdef WATT32
    {"wdebug", OPT_WDEBUG, '-', "WATT-32 tcp debugging"},
#endif
    {"nbio", OPT_NBIO, '-', "Use non-blocking IO"},
    {"psk_identity", OPT_PSK_IDENTITY, 's', "PSK identity"},
    {"psk", OPT_PSK, 's', "PSK in hex (without 0x)"},
771
    {"psk_session", OPT_PSK_SESS, '<', "File to read PSK SSL session from"},
772
#ifndef OPENSSL_NO_SRP
773
    {"srpuser", OPT_SRPUSER, 's', "SRP authentication for 'user'"},
774 775 776 777 778
    {"srppass", OPT_SRPPASS, 's', "Password for 'user'"},
    {"srp_lateuser", OPT_SRP_LATEUSER, '-',
     "SRP username into second ClientHello message"},
    {"srp_moregroups", OPT_SRP_MOREGROUPS, '-',
     "Tolerate other than the known g N values."},
779
    {"srp_strength", OPT_SRP_STRENGTH, 'p', "Minimal length in bits for N"},
780
#endif
781
#ifndef OPENSSL_NO_NEXTPROTONEG
782 783 784 785 786
    {"nextprotoneg", OPT_NEXTPROTONEG, 's',
     "Enable NPN extension, considering named protocols supported (comma-separated list)"},
#endif
#ifndef OPENSSL_NO_ENGINE
    {"engine", OPT_ENGINE, 's', "Use engine, possibly a hardware device"},
R
Rich Salz 已提交
787 788
    {"ssl_client_engine", OPT_SSL_CLIENT_ENGINE, 's',
     "Specify engine to be used for client certificate operations"},
789 790
#endif
#ifndef OPENSSL_NO_CT
791
    {"ct", OPT_CT, '-', "Request and parse SCTs (also enables OCSP stapling)"},
792 793
    {"noct", OPT_NOCT, '-', "Do not request or parse SCTs (default)"},
    {"ctlogfile", OPT_CTLOG_FILE, '<', "CT log list CONF file"},
794
#endif
795
    {"keylogfile", OPT_KEYLOG_FILE, '>', "Write TLS secrets to file"},
796
    {"early_data", OPT_EARLY_DATA, '<', "File to send as early data"},
797
    {"enable_pha", OPT_ENABLE_PHA, '-', "Enable post-handshake-authentication"},
798
    {NULL, OPT_EOF, 0x00, NULL}
799 800 801 802
};

typedef enum PROTOCOL_choice {
    PROTO_OFF,
803 804 805 806
    PROTO_SMTP,
    PROTO_POP3,
    PROTO_IMAP,
    PROTO_FTP,
807
    PROTO_TELNET,
808
    PROTO_XMPP,
809
    PROTO_XMPP_SERVER,
810
    PROTO_CONNECT,
V
Valentin Vidic 已提交
811
    PROTO_IRC,
K
Keigo Tanaka 已提交
812
    PROTO_MYSQL,
813
    PROTO_POSTGRES,
814
    PROTO_LMTP,
815
    PROTO_NNTP,
816 817
    PROTO_SIEVE,
    PROTO_LDAP
818 819
} PROTOCOL_CHOICE;

820
static const OPT_PAIR services[] = {
821 822 823 824 825
    {"smtp", PROTO_SMTP},
    {"pop3", PROTO_POP3},
    {"imap", PROTO_IMAP},
    {"ftp", PROTO_FTP},
    {"xmpp", PROTO_XMPP},
826
    {"xmpp-server", PROTO_XMPP_SERVER},
827
    {"telnet", PROTO_TELNET},
828
    {"irc", PROTO_IRC},
K
Keigo Tanaka 已提交
829
    {"mysql", PROTO_MYSQL},
V
Valentin Vidic 已提交
830
    {"postgres", PROTO_POSTGRES},
831
    {"lmtp", PROTO_LMTP},
832
    {"nntp", PROTO_NNTP},
833
    {"sieve", PROTO_SIEVE},
834
    {"ldap", PROTO_LDAP},
835
    {NULL, 0}
836 837
};

838 839 840 841
#define IS_INET_FLAG(o) \
 (o == OPT_4 || o == OPT_6 || o == OPT_HOST || o == OPT_PORT || o == OPT_CONNECT)
#define IS_UNIX_FLAG(o) (o == OPT_UNIX)

842 843
#define IS_PROT_FLAG(o) \
 (o == OPT_SSL3 || o == OPT_TLS1 || o == OPT_TLS1_1 || o == OPT_TLS1_2 \
844
  || o == OPT_TLS1_3 || o == OPT_DTLS || o == OPT_DTLS1 || o == OPT_DTLS1_2)
845

846 847 848 849 850 851 852 853 854
/* Free |*dest| and optionally set it to a copy of |source|. */
static void freeandcopy(char **dest, const char *source)
{
    OPENSSL_free(*dest);
    *dest = NULL;
    if (source != NULL)
        *dest = OPENSSL_strdup(source);
}

855
static int new_session_cb(SSL *s, SSL_SESSION *sess)
856 857
{

858 859 860 861 862 863 864 865 866 867 868 869 870 871 872 873 874 875 876 877
    if (sess_out != NULL) {
        BIO *stmp = BIO_new_file(sess_out, "w");

        if (stmp == NULL) {
            BIO_printf(bio_err, "Error writing session file %s\n", sess_out);
        } else {
            PEM_write_bio_SSL_SESSION(stmp, sess);
            BIO_free(stmp);
        }
    }

    /*
     * Session data gets dumped on connection for TLSv1.2 and below, and on
     * arrival of the NewSessionTicket for TLSv1.3.
     */
    if (SSL_version(s) == TLS1_3_VERSION) {
        BIO_printf(bio_c_out,
                   "---\nPost-Handshake New Session Ticket arrived:\n");
        SSL_SESSION_print(bio_c_out, sess);
        BIO_printf(bio_c_out, "---\n");
878 879 880 881 882 883 884 885 886
    }

    /*
     * We always return a "fail" response so that the session gets freed again
     * because we haven't used the reference.
     */
    return 0;
}

887
int s_client_main(int argc, char **argv)
888
{
889
    BIO *sbio;
890
    EVP_PKEY *key = NULL;
891
    SSL *con = NULL;
892
    SSL_CTX *ctx = NULL;
893 894
    STACK_OF(X509) *chain = NULL;
    X509 *cert = NULL;
895
    X509_VERIFY_PARAM *vpm = NULL;
896 897 898
    SSL_EXCERT *exc = NULL;
    SSL_CONF_CTX *cctx = NULL;
    STACK_OF(OPENSSL_STRING) *ssl_args = NULL;
V
Viktor Dukhovni 已提交
899 900
    char *dane_tlsa_domain = NULL;
    STACK_OF(OPENSSL_STRING) *dane_tlsa_rrset = NULL;
901
    int dane_ee_no_name = 0;
902
    STACK_OF(X509_CRL) *crls = NULL;
903
    const SSL_METHOD *meth = TLS_client_method();
904
    const char *CApath = NULL, *CAfile = NULL;
905 906 907 908
    char *cbuf = NULL, *sbuf = NULL, *mbuf = NULL;
    char *proxystr = NULL, *proxyuser = NULL;
    char *proxypassarg = NULL, *proxypass = NULL;
    char *connectstr = NULL, *bindstr = NULL;
V
Viktor Dukhovni 已提交
909
    char *cert_file = NULL, *key_file = NULL, *chain_file = NULL;
910
    char *chCApath = NULL, *chCAfile = NULL, *host = NULL;
911
    char *port = OPENSSL_strdup(PORT);
912
    char *bindhost = NULL, *bindport = NULL;
913
    char *passarg = NULL, *pass = NULL, *vfyCApath = NULL, *vfyCAfile = NULL;
D
Dr. Stephen Henson 已提交
914
    char *ReqCAfile = NULL;
915
    char *sess_in = NULL, *crl_file = NULL, *p;
916
    const char *protohost = NULL;
917
    struct timeval timeout, *timeoutp;
918
    fd_set readfds, writefds;
919
    int noCApath = 0, noCAfile = 0;
920 921 922
    int build_chain = 0, cbuf_len, cbuf_off, cert_format = FORMAT_PEM;
    int key_format = FORMAT_PEM, crlf = 0, full_log = 1, mbuf_len = 0;
    int prexit = 0;
M
Matt Caswell 已提交
923
    int sdebug = 0;
924
    int reconnect = 0, verify = SSL_VERIFY_NONE, vpmtouched = 0;
925
    int ret = 1, in_init = 1, i, nbio_test = 0, s = -1, k, width, state = 0;
926
    int sbuf_len, sbuf_off, cmdletters = 1;
M
Matt Caswell 已提交
927
    int socket_family = AF_UNSPEC, socket_type = SOCK_STREAM, protocol = 0;
928 929
    int starttls_proto = PROTO_OFF, crl_format = FORMAT_PEM, crl_download = 0;
    int write_tty, read_tty, write_ssl, read_ssl, tty_on, ssl_pending;
930
#if !defined(OPENSSL_SYS_WINDOWS) && !defined(OPENSSL_SYS_MSDOS)
931
    int at_eof = 0;
932
#endif
933
    int read_buf_len = 0;
934 935
    int fallback_scsv = 0;
    OPTION_CHOICE o;
M
Matt Caswell 已提交
936 937 938 939
#ifndef OPENSSL_NO_DTLS
    int enable_timeouts = 0;
    long socket_mtu = 0;
#endif
940
#ifndef OPENSSL_NO_ENGINE
941
    ENGINE *ssl_client_engine = NULL;
942
#endif
R
Rich Salz 已提交
943
    ENGINE *e = NULL;
R
Rich Salz 已提交
944
#if defined(OPENSSL_SYS_WINDOWS) || defined(OPENSSL_SYS_MSDOS)
945
    struct timeval tv;
946
#endif
M
Matt Caswell 已提交
947
    const char *servername = NULL;
948
    int noservername = 0;
949
    const char *alpn_in = NULL;
950
    tlsextctx tlsextcbp = { NULL, 0 };
951
    const char *ssl_config = NULL;
952
#define MAX_SI_TYPES 100
953 954
    unsigned short serverinfo_types[MAX_SI_TYPES];
    int serverinfo_count = 0, start = 0, len;
955
#ifndef OPENSSL_NO_NEXTPROTONEG
956
    const char *next_proto_neg_in = NULL;
D
Dr. Stephen Henson 已提交
957
#endif
B
Ben Laurie 已提交
958
#ifndef OPENSSL_NO_SRP
959 960 961 962
    char *srppass = NULL;
    int srp_lateuser = 0;
    SRP_ARG srp_arg = { NULL, NULL, 0, 0, 0, 1024 };
#endif
T
Todd Short 已提交
963
#ifndef OPENSSL_NO_SRTP
964
    char *srtp_profiles = NULL;
T
Todd Short 已提交
965
#endif
966 967
#ifndef OPENSSL_NO_CT
    char *ctlog_file = NULL;
968
    int ct_validation = 0;
969
#endif
970
    int min_version = 0, max_version = 0, prot_opt = 0, no_prot_opt = 0;
F
FdaSilvaYY 已提交
971
    int async = 0;
972
    unsigned int max_send_fragment = 0;
973
    unsigned int split_send_fragment = 0, max_pipelines = 0;
974 975
    enum { use_inet, use_unix, use_unknown } connect_type = use_unknown;
    int count4or6 = 0;
976
    uint8_t maxfraglen = 0;
F
FdaSilvaYY 已提交
977
    int c_nbio = 0, c_msg = 0, c_ign_eof = 0, c_brief = 0;
R
Richard Levitte 已提交
978 979 980 981
    int c_tlsextdebug = 0;
#ifndef OPENSSL_NO_OCSP
    int c_status_req = 0;
#endif
F
FdaSilvaYY 已提交
982
    BIO *bio_c_msg = NULL;
983
    const char *keylog_file = NULL, *early_data_file = NULL;
T
Todd Short 已提交
984
#ifndef OPENSSL_NO_DTLS
M
Matt Caswell 已提交
985
    int isdtls = 0;
T
Todd Short 已提交
986
#endif
987
    char *psksessf = NULL;
988
    int enable_pha = 0;
989 990 991
#ifndef OPENSSL_NO_SCTP
    int sctp_label_bug = 0;
#endif
992

993 994 995 996 997 998 999 1000 1001 1002
    FD_ZERO(&readfds);
    FD_ZERO(&writefds);
/* Known false-positive of MemorySanitizer. */
#if defined(__has_feature)
# if __has_feature(memory_sanitizer)
    __msan_unpoison(&readfds, sizeof(readfds));
    __msan_unpoison(&writefds, sizeof(writefds));
# endif
#endif

1003
    prog = opt_progname(argv[0]);
1004 1005 1006
    c_quiet = 0;
    c_debug = 0;
    c_showcerts = 0;
1007 1008
    c_nbio = 0;
    vpm = X509_VERIFY_PARAM_new();
1009 1010
    cctx = SSL_CONF_CTX_new();

R
Rich Salz 已提交
1011
    if (vpm == NULL || cctx == NULL) {
1012
        BIO_printf(bio_err, "%s: out of memory\n", prog);
1013 1014 1015
        goto end;
    }

1016 1017 1018 1019
    cbuf = app_malloc(BUFSIZZ, "cbuf");
    sbuf = app_malloc(BUFSIZZ, "sbuf");
    mbuf = app_malloc(BUFSIZZ, "mbuf");

1020
    SSL_CONF_CTX_set_flags(cctx, SSL_CONF_FLAG_CLIENT | SSL_CONF_FLAG_CMDLINE);
1021

1022 1023
    prog = opt_init(argc, argv, s_client_options);
    while ((o = opt_next()) != OPT_EOF) {
1024 1025 1026
        /* Check for intermixing flags. */
        if (connect_type == use_unix && IS_INET_FLAG(o)) {
            BIO_printf(bio_err,
F
FdaSilvaYY 已提交
1027 1028
                       "%s: Intermixed protocol flags (unix and internet domains)\n",
                       prog);
1029 1030 1031 1032
            goto end;
        }
        if (connect_type == use_inet && IS_UNIX_FLAG(o)) {
            BIO_printf(bio_err,
F
FdaSilvaYY 已提交
1033 1034
                       "%s: Intermixed protocol flags (internet and unix domains)\n",
                       prog);
1035 1036
            goto end;
        }
1037 1038 1039 1040 1041 1042 1043 1044

        if (IS_PROT_FLAG(o) && ++prot_opt > 1) {
            BIO_printf(bio_err, "Cannot supply multiple protocol flags\n");
            goto end;
        }
        if (IS_NO_PROT_FLAG(o))
            no_prot_opt++;
        if (prot_opt == 1 && no_prot_opt) {
F
FdaSilvaYY 已提交
1045 1046
            BIO_printf(bio_err,
                       "Cannot supply both a protocol flag and '-no_<prot>'\n");
1047 1048 1049
            goto end;
        }

1050 1051 1052 1053 1054 1055 1056 1057 1058 1059
        switch (o) {
        case OPT_EOF:
        case OPT_ERR:
 opthelp:
            BIO_printf(bio_err, "%s: Use -help for summary.\n", prog);
            goto end;
        case OPT_HELP:
            opt_help(s_client_options);
            ret = 0;
            goto end;
1060
        case OPT_4:
1061
            connect_type = use_inet;
1062
            socket_family = AF_INET;
1063
            count4or6++;
1064 1065
            break;
#ifdef AF_INET6
1066 1067 1068 1069
        case OPT_6:
            connect_type = use_inet;
            socket_family = AF_INET6;
            count4or6++;
1070 1071
            break;
#endif
1072 1073
        case OPT_HOST:
            connect_type = use_inet;
1074
            freeandcopy(&host, opt_arg());
1075 1076
            break;
        case OPT_PORT:
1077
            connect_type = use_inet;
1078
            freeandcopy(&port, opt_arg());
1079 1080
            break;
        case OPT_CONNECT:
1081
            connect_type = use_inet;
1082
            freeandcopy(&connectstr, opt_arg());
1083
            break;
1084 1085 1086
        case OPT_BIND:
            freeandcopy(&bindstr, opt_arg());
            break;
1087 1088 1089
        case OPT_PROXY:
            proxystr = opt_arg();
            starttls_proto = PROTO_CONNECT;
1090
            break;
1091 1092 1093 1094 1095 1096
        case OPT_PROXY_USER:
            proxyuser = opt_arg();
            break;
        case OPT_PROXY_PASS:
            proxypassarg = opt_arg();
            break;
1097
#ifdef AF_UNIX
1098
        case OPT_UNIX:
1099
            connect_type = use_unix;
1100
            socket_family = AF_UNIX;
1101
            freeandcopy(&host, opt_arg());
1102
            break;
1103
#endif
1104
        case OPT_XMPPHOST:
1105 1106 1107
            /* fall through, since this is an alias */
        case OPT_PROTOHOST:
            protohost = opt_arg();
1108
            break;
1109
        case OPT_VERIFY:
1110
            verify = SSL_VERIFY_PEER;
1111
            verify_args.depth = atoi(opt_arg());
1112
            if (!c_quiet)
1113
                BIO_printf(bio_err, "verify depth is %d\n", verify_args.depth);
1114 1115 1116 1117
            break;
        case OPT_CERT:
            cert_file = opt_arg();
            break;
1118 1119 1120 1121
        case OPT_NAMEOPT:
            if (!set_nameopt(opt_arg()))
                goto end;
            break;
1122 1123 1124 1125
        case OPT_CRL:
            crl_file = opt_arg();
            break;
        case OPT_CRL_DOWNLOAD:
1126
            crl_download = 1;
1127 1128 1129 1130 1131 1132 1133 1134 1135 1136 1137 1138 1139 1140 1141 1142
            break;
        case OPT_SESS_OUT:
            sess_out = opt_arg();
            break;
        case OPT_SESS_IN:
            sess_in = opt_arg();
            break;
        case OPT_CERTFORM:
            if (!opt_format(opt_arg(), OPT_FMT_PEMDER, &cert_format))
                goto opthelp;
            break;
        case OPT_CRLFORM:
            if (!opt_format(opt_arg(), OPT_FMT_PEMDER, &crl_format))
                goto opthelp;
            break;
        case OPT_VERIFY_RET_ERROR:
1143
            verify = SSL_VERIFY_PEER;
1144
            verify_args.return_error = 1;
1145 1146
            break;
        case OPT_VERIFY_QUIET:
1147
            verify_args.quiet = 1;
1148 1149
            break;
        case OPT_BRIEF:
1150
            c_brief = verify_args.quiet = c_quiet = 1;
1151 1152 1153 1154 1155 1156 1157 1158 1159 1160 1161 1162 1163 1164 1165 1166 1167 1168 1169 1170 1171
            break;
        case OPT_S_CASES:
            if (ssl_args == NULL)
                ssl_args = sk_OPENSSL_STRING_new_null();
            if (ssl_args == NULL
                || !sk_OPENSSL_STRING_push(ssl_args, opt_flag())
                || !sk_OPENSSL_STRING_push(ssl_args, opt_arg())) {
                BIO_printf(bio_err, "%s: Memory allocation failure\n", prog);
                goto end;
            }
            break;
        case OPT_V_CASES:
            if (!opt_verify(o, vpm))
                goto end;
            vpmtouched++;
            break;
        case OPT_X_CASES:
            if (!args_excert(o, &exc))
                goto end;
            break;
        case OPT_PREXIT:
1172
            prexit = 1;
1173 1174
            break;
        case OPT_CRLF:
1175
            crlf = 1;
1176 1177 1178 1179 1180 1181 1182
            break;
        case OPT_QUIET:
            c_quiet = c_ign_eof = 1;
            break;
        case OPT_NBIO:
            c_nbio = 1;
            break;
R
Rich Salz 已提交
1183 1184 1185
        case OPT_NOCMDS:
            cmdletters = 0;
            break;
1186
        case OPT_ENGINE:
R
Rich Salz 已提交
1187
            e = setup_engine(opt_arg(), 1);
1188 1189
            break;
        case OPT_SSL_CLIENT_ENGINE:
R
Rich Salz 已提交
1190 1191 1192 1193 1194 1195 1196
#ifndef OPENSSL_NO_ENGINE
            ssl_client_engine = ENGINE_by_id(opt_arg());
            if (ssl_client_engine == NULL) {
                BIO_printf(bio_err, "Error getting client auth engine\n");
                goto opthelp;
            }
#endif
1197
            break;
R
Rich Salz 已提交
1198 1199 1200
        case OPT_R_CASES:
            if (!opt_rand(o))
                goto end;
1201 1202
            break;
        case OPT_IGN_EOF:
1203
            c_ign_eof = 1;
1204 1205
            break;
        case OPT_NO_IGN_EOF:
1206
            c_ign_eof = 0;
1207 1208
            break;
        case OPT_DEBUG:
1209
            c_debug = 1;
1210 1211
            break;
        case OPT_TLSEXTDEBUG:
1212
            c_tlsextdebug = 1;
1213 1214
            break;
        case OPT_STATUS:
R
Richard Levitte 已提交
1215
#ifndef OPENSSL_NO_OCSP
1216
            c_status_req = 1;
R
Richard Levitte 已提交
1217
#endif
1218 1219
            break;
        case OPT_WDEBUG:
1220
#ifdef WATT32
1221 1222
            dbug_init();
#endif
1223
            break;
1224
        case OPT_MSG:
1225
            c_msg = 1;
1226 1227 1228 1229 1230
            break;
        case OPT_MSGFILE:
            bio_c_msg = BIO_new_file(opt_arg(), "w");
            break;
        case OPT_TRACE:
1231
#ifndef OPENSSL_NO_SSL_TRACE
1232 1233
            c_msg = 2;
#endif
1234
            break;
1235
        case OPT_SECURITY_DEBUG:
1236
            sdebug = 1;
1237 1238
            break;
        case OPT_SECURITY_DEBUG_VERBOSE:
1239
            sdebug = 2;
1240 1241
            break;
        case OPT_SHOWCERTS:
1242
            c_showcerts = 1;
1243 1244
            break;
        case OPT_NBIO_TEST:
1245
            nbio_test = 1;
1246 1247
            break;
        case OPT_STATE:
1248
            state = 1;
1249 1250 1251 1252 1253 1254
            break;
        case OPT_PSK_IDENTITY:
            psk_identity = opt_arg();
            break;
        case OPT_PSK:
            for (p = psk_key = opt_arg(); *p; p++) {
1255
                if (isxdigit(_UC(*p)))
1256
                    continue;
1257 1258
                BIO_printf(bio_err, "Not a hex number '%s'\n", psk_key);
                goto end;
1259
            }
D
Dr. Stephen Henson 已提交
1260
            break;
1261 1262 1263
        case OPT_PSK_SESS:
            psksessf = opt_arg();
            break;
B
Ben Laurie 已提交
1264
#ifndef OPENSSL_NO_SRP
1265 1266
        case OPT_SRPUSER:
            srp_arg.srplogin = opt_arg();
1267 1268
            if (min_version < TLS1_VERSION)
                min_version = TLS1_VERSION;
1269 1270 1271
            break;
        case OPT_SRPPASS:
            srppass = opt_arg();
1272 1273
            if (min_version < TLS1_VERSION)
                min_version = TLS1_VERSION;
1274 1275 1276
            break;
        case OPT_SRP_STRENGTH:
            srp_arg.strength = atoi(opt_arg());
1277 1278
            BIO_printf(bio_err, "SRP minimal length for N is %d\n",
                       srp_arg.strength);
1279 1280
            if (min_version < TLS1_VERSION)
                min_version = TLS1_VERSION;
1281 1282
            break;
        case OPT_SRP_LATEUSER:
1283
            srp_lateuser = 1;
1284 1285
            if (min_version < TLS1_VERSION)
                min_version = TLS1_VERSION;
1286 1287
            break;
        case OPT_SRP_MOREGROUPS:
1288
            srp_arg.amp = 1;
1289 1290
            if (min_version < TLS1_VERSION)
                min_version = TLS1_VERSION;
1291
            break;
B
Ben Laurie 已提交
1292
#endif
1293 1294 1295
        case OPT_SSL_CONFIG:
            ssl_config = opt_arg();
            break;
1296
        case OPT_SSL3:
1297 1298
            min_version = SSL3_VERSION;
            max_version = SSL3_VERSION;
1299
            break;
1300 1301 1302 1303
        case OPT_TLS1_3:
            min_version = TLS1_3_VERSION;
            max_version = TLS1_3_VERSION;
            break;
1304
        case OPT_TLS1_2:
1305 1306
            min_version = TLS1_2_VERSION;
            max_version = TLS1_2_VERSION;
1307 1308
            break;
        case OPT_TLS1_1:
1309 1310
            min_version = TLS1_1_VERSION;
            max_version = TLS1_1_VERSION;
1311 1312
            break;
        case OPT_TLS1:
1313 1314
            min_version = TLS1_VERSION;
            max_version = TLS1_VERSION;
1315 1316
            break;
        case OPT_DTLS:
1317
#ifndef OPENSSL_NO_DTLS
1318 1319
            meth = DTLS_client_method();
            socket_type = SOCK_DGRAM;
M
Matt Caswell 已提交
1320
            isdtls = 1;
1321
#endif
1322 1323
            break;
        case OPT_DTLS1:
1324
#ifndef OPENSSL_NO_DTLS1
1325 1326 1327
            meth = DTLS_client_method();
            min_version = DTLS1_VERSION;
            max_version = DTLS1_VERSION;
1328
            socket_type = SOCK_DGRAM;
M
Matt Caswell 已提交
1329
            isdtls = 1;
1330
#endif
1331 1332
            break;
        case OPT_DTLS1_2:
1333
#ifndef OPENSSL_NO_DTLS1_2
1334 1335 1336
            meth = DTLS_client_method();
            min_version = DTLS1_2_VERSION;
            max_version = DTLS1_2_VERSION;
1337
            socket_type = SOCK_DGRAM;
M
Matt Caswell 已提交
1338 1339 1340 1341 1342 1343
            isdtls = 1;
#endif
            break;
        case OPT_SCTP:
#ifndef OPENSSL_NO_SCTP
            protocol = IPPROTO_SCTP;
1344 1345 1346 1347 1348
#endif
            break;
        case OPT_SCTP_LABEL_BUG:
#ifndef OPENSSL_NO_SCTP
            sctp_label_bug = 1;
1349
#endif
1350 1351
            break;
        case OPT_TIMEOUT:
1352
#ifndef OPENSSL_NO_DTLS
1353
            enable_timeouts = 1;
1354
#endif
1355 1356
            break;
        case OPT_MTU:
1357
#ifndef OPENSSL_NO_DTLS
1358
            socket_mtu = atol(opt_arg());
1359
#endif
1360
            break;
1361
        case OPT_FALLBACKSCSV:
1362
            fallback_scsv = 1;
1363 1364
            break;
        case OPT_KEYFORM:
1365
            if (!opt_format(opt_arg(), OPT_FMT_PDE, &key_format))
1366 1367 1368 1369 1370 1371 1372 1373 1374 1375 1376 1377
                goto opthelp;
            break;
        case OPT_PASS:
            passarg = opt_arg();
            break;
        case OPT_CERT_CHAIN:
            chain_file = opt_arg();
            break;
        case OPT_KEY:
            key_file = opt_arg();
            break;
        case OPT_RECONNECT:
1378
            reconnect = 5;
1379 1380 1381 1382
            break;
        case OPT_CAPATH:
            CApath = opt_arg();
            break;
1383 1384 1385
        case OPT_NOCAPATH:
            noCApath = 1;
            break;
1386 1387 1388 1389 1390 1391 1392
        case OPT_CHAINCAPATH:
            chCApath = opt_arg();
            break;
        case OPT_VERIFYCAPATH:
            vfyCApath = opt_arg();
            break;
        case OPT_BUILD_CHAIN:
1393
            build_chain = 1;
1394
            break;
D
Dr. Stephen Henson 已提交
1395 1396 1397
        case OPT_REQCAFILE:
            ReqCAfile = opt_arg();
            break;
1398 1399 1400
        case OPT_CAFILE:
            CAfile = opt_arg();
            break;
1401 1402 1403
        case OPT_NOCAFILE:
            noCAfile = 1;
            break;
1404 1405
#ifndef OPENSSL_NO_CT
        case OPT_NOCT:
1406
            ct_validation = 0;
1407
            break;
1408 1409
        case OPT_CT:
            ct_validation = 1;
1410 1411 1412 1413 1414
            break;
        case OPT_CTLOG_FILE:
            ctlog_file = opt_arg();
            break;
#endif
1415 1416 1417 1418 1419 1420
        case OPT_CHAINCAFILE:
            chCAfile = opt_arg();
            break;
        case OPT_VERIFYCAFILE:
            vfyCAfile = opt_arg();
            break;
V
Viktor Dukhovni 已提交
1421 1422 1423 1424 1425 1426 1427 1428 1429 1430 1431 1432
        case OPT_DANE_TLSA_DOMAIN:
            dane_tlsa_domain = opt_arg();
            break;
        case OPT_DANE_TLSA_RRDATA:
            if (dane_tlsa_rrset == NULL)
                dane_tlsa_rrset = sk_OPENSSL_STRING_new_null();
            if (dane_tlsa_rrset == NULL ||
                !sk_OPENSSL_STRING_push(dane_tlsa_rrset, opt_arg())) {
                BIO_printf(bio_err, "%s: Memory allocation failure\n", prog);
                goto end;
            }
            break;
1433 1434 1435
        case OPT_DANE_EE_NO_NAME:
            dane_ee_no_name = 1;
            break;
1436
        case OPT_NEXTPROTONEG:
M
Matt Caswell 已提交
1437
#ifndef OPENSSL_NO_NEXTPROTONEG
1438
            next_proto_neg_in = opt_arg();
M
Matt Caswell 已提交
1439
#endif
1440 1441 1442 1443 1444 1445 1446 1447 1448 1449 1450 1451
            break;
        case OPT_ALPN:
            alpn_in = opt_arg();
            break;
        case OPT_SERVERINFO:
            p = opt_arg();
            len = strlen(p);
            for (start = 0, i = 0; i <= len; ++i) {
                if (i == len || p[i] == ',') {
                    serverinfo_types[serverinfo_count] = atoi(p + start);
                    if (++serverinfo_count == MAX_SI_TYPES)
                        break;
1452 1453 1454
                    start = i + 1;
                }
            }
1455 1456 1457 1458
            break;
        case OPT_STARTTLS:
            if (!opt_pair(opt_arg(), services, &starttls_proto))
                goto end;
1459
            break;
1460 1461 1462
        case OPT_SERVERNAME:
            servername = opt_arg();
            break;
1463 1464 1465
        case OPT_NOSERVERNAME:
            noservername = 1;
            break;
1466
        case OPT_USE_SRTP:
T
Todd Short 已提交
1467
#ifndef OPENSSL_NO_SRTP
1468
            srtp_profiles = opt_arg();
T
Todd Short 已提交
1469
#endif
1470 1471 1472 1473 1474 1475
            break;
        case OPT_KEYMATEXPORT:
            keymatexportlabel = opt_arg();
            break;
        case OPT_KEYMATEXPORTLEN:
            keymatexportlen = atoi(opt_arg());
1476
            break;
1477 1478 1479
        case OPT_ASYNC:
            async = 1;
            break;
1480 1481 1482 1483 1484 1485 1486 1487 1488 1489 1490 1491 1492 1493 1494 1495 1496 1497 1498 1499 1500 1501
        case OPT_MAXFRAGLEN:
            len = atoi(opt_arg());
            switch (len) {
            case 512:
                maxfraglen = TLSEXT_max_fragment_length_512;
                break;
            case 1024:
                maxfraglen = TLSEXT_max_fragment_length_1024;
                break;
            case 2048:
                maxfraglen = TLSEXT_max_fragment_length_2048;
                break;
            case 4096:
                maxfraglen = TLSEXT_max_fragment_length_4096;
                break;
            default:
                BIO_printf(bio_err,
                           "%s: Max Fragment Len %u is out of permitted values",
                           prog, len);
                goto opthelp;
            }
            break;
1502 1503 1504
        case OPT_MAX_SEND_FRAG:
            max_send_fragment = atoi(opt_arg());
            break;
1505 1506 1507 1508 1509 1510
        case OPT_SPLIT_SEND_FRAG:
            split_send_fragment = atoi(opt_arg());
            break;
        case OPT_MAX_PIPELINES:
            max_pipelines = atoi(opt_arg());
            break;
1511 1512 1513
        case OPT_READ_BUF:
            read_buf_len = atoi(opt_arg());
            break;
1514 1515 1516
        case OPT_KEYLOG_FILE:
            keylog_file = opt_arg();
            break;
1517 1518 1519
        case OPT_EARLY_DATA:
            early_data_file = opt_arg();
            break;
1520 1521
        case OPT_ENABLE_PHA:
            enable_pha = 1;
1522
            break;
1523 1524
        }
    }
1525

1526 1527 1528 1529
    if (count4or6 >= 2) {
        BIO_printf(bio_err, "%s: Can't use both -4 and -6\n", prog);
        goto opthelp;
    }
1530 1531 1532 1533 1534 1535 1536 1537 1538 1539 1540 1541 1542 1543
    if (noservername) {
        if (servername != NULL) {
            BIO_printf(bio_err,
                       "%s: Can't use -servername and -noservername together\n",
                       prog);
            goto opthelp;
        }
        if (dane_tlsa_domain != NULL) {
            BIO_printf(bio_err,
               "%s: Can't use -dane_tlsa_domain and -noservername together\n",
               prog);
            goto opthelp;
        }
    }
1544
    argc = opt_num_rest();
1545 1546 1547 1548 1549 1550 1551 1552 1553 1554 1555 1556
    if (argc == 1) {
        /* If there's a positional argument, it's the equivalent of
         * OPT_CONNECT.
         * Don't allow -connect and a separate argument.
         */
        if (connectstr != NULL) {
            BIO_printf(bio_err,
                       "%s: must not provide both -connect option and target parameter\n",
                       prog);
            goto opthelp;
        }
        connect_type = use_inet;
1557
        freeandcopy(&connectstr, *opt_rest());
1558
    } else if (argc != 0) {
K
Kurt Roeckx 已提交
1559
        goto opthelp;
1560
    }
1561

1562 1563 1564 1565 1566 1567
#ifndef OPENSSL_NO_NEXTPROTONEG
    if (min_version == TLS1_3_VERSION && next_proto_neg_in != NULL) {
        BIO_printf(bio_err, "Cannot supply -nextprotoneg with TLSv1.3\n");
        goto opthelp;
    }
#endif
1568
    if (proxystr != NULL) {
1569 1570
        int res;
        char *tmp_host = host, *tmp_port = port;
1571
        if (connectstr == NULL) {
1572
            BIO_printf(bio_err, "%s: -proxy requires use of -connect or target parameter\n", prog);
1573 1574
            goto opthelp;
        }
1575 1576 1577 1578 1579 1580
        res = BIO_parse_hostserv(proxystr, &host, &port, BIO_PARSE_PRIO_HOST);
        if (tmp_host != host)
            OPENSSL_free(tmp_host);
        if (tmp_port != port)
            OPENSSL_free(tmp_port);
        if (!res) {
F
FdaSilvaYY 已提交
1581 1582
            BIO_printf(bio_err,
                       "%s: -proxy argument malformed or ambiguous\n", prog);
1583 1584 1585 1586 1587 1588 1589 1590 1591 1592 1593 1594 1595 1596
            goto end;
        }
    } else {
        int res = 1;
        char *tmp_host = host, *tmp_port = port;
        if (connectstr != NULL)
            res = BIO_parse_hostserv(connectstr, &host, &port,
                                     BIO_PARSE_PRIO_HOST);
        if (tmp_host != host)
            OPENSSL_free(tmp_host);
        if (tmp_port != port)
            OPENSSL_free(tmp_port);
        if (!res) {
            BIO_printf(bio_err,
1597
                       "%s: -connect argument or target parameter malformed or ambiguous\n",
1598
                       prog);
1599
            goto end;
1600
        }
1601 1602
    }

1603 1604 1605 1606 1607 1608 1609 1610 1611 1612 1613 1614
    if (bindstr != NULL) {
        int res;
        res = BIO_parse_hostserv(bindstr, &bindhost, &bindport,
                                 BIO_PARSE_PRIO_HOST);
        if (!res) {
            BIO_printf(bio_err,
                       "%s: -bind argument parameter malformed or ambiguous\n",
                       prog);
            goto end;
        }
    }

1615
#ifdef AF_UNIX
1616
    if (socket_family == AF_UNIX && socket_type != SOCK_STREAM) {
1617 1618 1619 1620
        BIO_printf(bio_err,
                   "Can't use unix sockets and datagrams together\n");
        goto end;
    }
1621
#endif
1622

M
Matt Caswell 已提交
1623 1624 1625 1626 1627 1628 1629 1630 1631 1632
#ifndef OPENSSL_NO_SCTP
    if (protocol == IPPROTO_SCTP) {
        if (socket_type != SOCK_DGRAM) {
            BIO_printf(bio_err, "Can't use -sctp without DTLS\n");
            goto end;
        }
        /* SCTP is unusual. It uses DTLS over a SOCK_STREAM protocol */
        socket_type = SOCK_STREAM;
    }
#endif
1633

1634
#if !defined(OPENSSL_NO_NEXTPROTONEG)
1635 1636 1637 1638 1639 1640 1641 1642 1643 1644
    next_proto.status = -1;
    if (next_proto_neg_in) {
        next_proto.data =
            next_protos_parse(&next_proto.len, next_proto_neg_in);
        if (next_proto.data == NULL) {
            BIO_printf(bio_err, "Error parsing -nextprotoneg argument\n");
            goto end;
        }
    } else
        next_proto.data = NULL;
B
Ben Laurie 已提交
1645 1646
#endif

1647
    if (!app_passwd(passarg, NULL, &pass, NULL)) {
1648 1649 1650 1651 1652 1653 1654 1655 1656 1657 1658
        BIO_printf(bio_err, "Error getting private key password\n");
        goto end;
    }

    if (!app_passwd(proxypassarg, NULL, &proxypass, NULL)) {
        BIO_printf(bio_err, "Error getting proxy password\n");
        goto end;
    }

    if (proxypass != NULL && proxyuser == NULL) {
        BIO_printf(bio_err, "Error: Must specify proxy_user with proxy_pass\n");
1659 1660 1661 1662 1663 1664
        goto end;
    }

    if (key_file == NULL)
        key_file = cert_file;

1665
    if (key_file != NULL) {
1666
        key = load_key(key_file, key_format, 0, pass, e,
1667
                       "client certificate private key file");
1668
        if (key == NULL) {
1669 1670 1671 1672 1673
            ERR_print_errors(bio_err);
            goto end;
        }
    }

1674
    if (cert_file != NULL) {
1675
        cert = load_cert(cert_file, cert_format, "client certificate file");
1676
        if (cert == NULL) {
1677 1678 1679 1680 1681
            ERR_print_errors(bio_err);
            goto end;
        }
    }

1682
    if (chain_file != NULL) {
1683
        if (!load_certs(chain_file, &chain, FORMAT_PEM, NULL,
1684
                        "client certificate chain"))
1685 1686 1687
            goto end;
    }

1688
    if (crl_file != NULL) {
1689 1690
        X509_CRL *crl;
        crl = load_crl(crl_file, crl_format);
1691
        if (crl == NULL) {
1692 1693 1694 1695 1696
            BIO_puts(bio_err, "Error loading CRL\n");
            ERR_print_errors(bio_err);
            goto end;
        }
        crls = sk_X509_CRL_new_null();
1697
        if (crls == NULL || !sk_X509_CRL_push(crls, crl)) {
1698 1699 1700 1701 1702 1703 1704
            BIO_puts(bio_err, "Error adding CRL\n");
            ERR_print_errors(bio_err);
            X509_CRL_free(crl);
            goto end;
        }
    }

1705
    if (!load_excert(&exc))
1706 1707 1708 1709 1710
        goto end;

    if (bio_c_out == NULL) {
        if (c_quiet && !c_debug) {
            bio_c_out = BIO_new(BIO_s_null());
1711
            if (c_msg && bio_c_msg == NULL)
1712
                bio_c_msg = dup_bio_out(FORMAT_TEXT);
1713
        } else if (bio_c_out == NULL)
1714
            bio_c_out = dup_bio_out(FORMAT_TEXT);
1715
    }
B
Ben Laurie 已提交
1716
#ifndef OPENSSL_NO_SRP
1717
    if (!app_passwd(srppass, NULL, &srp_arg.srppassin, NULL)) {
1718 1719 1720 1721 1722 1723 1724 1725 1726 1727 1728
        BIO_printf(bio_err, "Error getting password\n");
        goto end;
    }
#endif

    ctx = SSL_CTX_new(meth);
    if (ctx == NULL) {
        ERR_print_errors(bio_err);
        goto end;
    }

1729 1730
    SSL_CTX_clear_mode(ctx, SSL_MODE_AUTO_RETRY);

1731
    if (sdebug)
R
Rich Salz 已提交
1732
        ssl_ctx_security_debug(ctx, sdebug);
1733

1734 1735 1736
    if (!config_ctx(cctx, ssl_args, ctx))
        goto end;

1737
    if (ssl_config != NULL) {
1738 1739 1740
        if (SSL_CTX_config(ctx, ssl_config) == 0) {
            BIO_printf(bio_err, "Error using configuration \"%s\"\n",
                       ssl_config);
F
FdaSilvaYY 已提交
1741 1742
            ERR_print_errors(bio_err);
            goto end;
1743 1744 1745
        }
    }

1746 1747 1748 1749 1750
#ifndef OPENSSL_NO_SCTP
    if (protocol == IPPROTO_SCTP && sctp_label_bug == 1)
        SSL_CTX_set_mode(ctx, SSL_MODE_DTLS_SCTP_LABEL_LENGTH_BUG);
#endif

1751 1752
    if (min_version != 0
        && SSL_CTX_set_min_proto_version(ctx, min_version) == 0)
1753
        goto end;
1754 1755
    if (max_version != 0
        && SSL_CTX_set_max_proto_version(ctx, max_version) == 0)
1756 1757
        goto end;

1758
    if (vpmtouched && !SSL_CTX_set1_param(ctx, vpm)) {
M
Matt Caswell 已提交
1759 1760 1761 1762
        BIO_printf(bio_err, "Error setting verify params\n");
        ERR_print_errors(bio_err);
        goto end;
    }
1763

M
Matt Caswell 已提交
1764
    if (async) {
1765
        SSL_CTX_set_mode(ctx, SSL_MODE_ASYNC);
M
Matt Caswell 已提交
1766
    }
1767

1768 1769 1770 1771 1772 1773
    if (max_send_fragment > 0
        && !SSL_CTX_set_max_send_fragment(ctx, max_send_fragment)) {
        BIO_printf(bio_err, "%s: Max send fragment size %u is out of permitted range\n",
                   prog, max_send_fragment);
        goto end;
    }
1774

1775 1776 1777 1778 1779
    if (split_send_fragment > 0
        && !SSL_CTX_set_split_send_fragment(ctx, split_send_fragment)) {
        BIO_printf(bio_err, "%s: Split send fragment size %u is out of permitted range\n",
                   prog, split_send_fragment);
        goto end;
1780
    }
1781 1782 1783 1784 1785 1786

    if (max_pipelines > 0
        && !SSL_CTX_set_max_pipelines(ctx, max_pipelines)) {
        BIO_printf(bio_err, "%s: Max pipelines %u is out of permitted range\n",
                   prog, max_pipelines);
        goto end;
1787
    }
1788

1789 1790 1791 1792
    if (read_buf_len > 0) {
        SSL_CTX_set_default_read_buffer_len(ctx, read_buf_len);
    }

1793 1794 1795 1796 1797 1798 1799 1800
    if (maxfraglen > 0
            && !SSL_CTX_set_tlsext_max_fragment_length(ctx, maxfraglen)) {
        BIO_printf(bio_err,
                   "%s: Max Fragment Length code %u is out of permitted values"
                   "\n", prog, maxfraglen);
        goto end;
    }

1801 1802 1803 1804 1805 1806
    if (!ssl_load_stores(ctx, vfyCApath, vfyCAfile, chCApath, chCAfile,
                         crls, crl_download)) {
        BIO_printf(bio_err, "Error loading store locations\n");
        ERR_print_errors(bio_err);
        goto end;
    }
D
Dr. Stephen Henson 已提交
1807 1808
    if (ReqCAfile != NULL) {
        STACK_OF(X509_NAME) *nm = sk_X509_NAME_new_null();
1809

D
Dr. Stephen Henson 已提交
1810 1811 1812 1813 1814 1815 1816 1817
        if (nm == NULL || !SSL_add_file_cert_subjects_to_stack(nm, ReqCAfile)) {
            sk_X509_NAME_pop_free(nm, X509_NAME_free);
            BIO_printf(bio_err, "Error loading CA names\n");
            ERR_print_errors(bio_err);
            goto end;
        }
        SSL_CTX_set0_CA_list(ctx, nm);
    }
1818
#ifndef OPENSSL_NO_ENGINE
1819 1820 1821 1822 1823 1824 1825 1826 1827
    if (ssl_client_engine) {
        if (!SSL_CTX_set_client_cert_engine(ctx, ssl_client_engine)) {
            BIO_puts(bio_err, "Error setting client auth engine\n");
            ERR_print_errors(bio_err);
            ENGINE_free(ssl_client_engine);
            goto end;
        }
        ENGINE_free(ssl_client_engine);
    }
1828 1829
#endif

1830
#ifndef OPENSSL_NO_PSK
R
Rich Salz 已提交
1831
    if (psk_key != NULL) {
1832
        if (c_debug)
F
FdaSilvaYY 已提交
1833
            BIO_printf(bio_c_out, "PSK key given, setting client callback\n");
1834 1835
        SSL_CTX_set_psk_client_callback(ctx, psk_client_cb);
    }
P
Piotr Sikora 已提交
1836
#endif
1837 1838 1839 1840 1841 1842 1843 1844 1845 1846 1847 1848 1849 1850 1851 1852
    if (psksessf != NULL) {
        BIO *stmp = BIO_new_file(psksessf, "r");

        if (stmp == NULL) {
            BIO_printf(bio_err, "Can't open PSK session file %s\n", psksessf);
            ERR_print_errors(bio_err);
            goto end;
        }
        psksess = PEM_read_bio_SSL_SESSION(stmp, NULL, 0, NULL);
        BIO_free(stmp);
        if (psksess == NULL) {
            BIO_printf(bio_err, "Can't read PSK session file %s\n", psksessf);
            ERR_print_errors(bio_err);
            goto end;
        }
    }
1853 1854 1855
    if (psk_key != NULL || psksess != NULL)
        SSL_CTX_set_psk_use_session_callback(ctx, psk_use_session_cb);

P
Piotr Sikora 已提交
1856
#ifndef OPENSSL_NO_SRTP
M
Matt Caswell 已提交
1857
    if (srtp_profiles != NULL) {
1858 1859
        /* Returns 0 on success! */
        if (SSL_CTX_set_tlsext_use_srtp(ctx, srtp_profiles) != 0) {
M
Matt Caswell 已提交
1860 1861 1862 1863 1864
            BIO_printf(bio_err, "Error setting SRTP profile\n");
            ERR_print_errors(bio_err);
            goto end;
        }
    }
1865
#endif
1866

1867
    if (exc != NULL)
1868
        ssl_ctx_set_excert(ctx, exc);
1869

1870
#if !defined(OPENSSL_NO_NEXTPROTONEG)
1871
    if (next_proto.data != NULL)
1872
        SSL_CTX_set_next_proto_select_cb(ctx, next_proto_cb, &next_proto);
1873
#endif
1874
    if (alpn_in) {
T
Todd Short 已提交
1875
        size_t alpn_len;
1876 1877 1878 1879 1880 1881
        unsigned char *alpn = next_protos_parse(&alpn_len, alpn_in);

        if (alpn == NULL) {
            BIO_printf(bio_err, "Error parsing -alpn argument\n");
            goto end;
        }
1882 1883
        /* Returns 0 on success! */
        if (SSL_CTX_set_alpn_protos(ctx, alpn, alpn_len) != 0) {
F
FdaSilvaYY 已提交
1884
            BIO_printf(bio_err, "Error setting ALPN\n");
M
Matt Caswell 已提交
1885 1886
            goto end;
        }
1887 1888
        OPENSSL_free(alpn);
    }
1889

1890
    for (i = 0; i < serverinfo_count; i++) {
V
Viktor Dukhovni 已提交
1891
        if (!SSL_CTX_add_client_custom_ext(ctx,
1892 1893 1894 1895
                                           serverinfo_types[i],
                                           NULL, NULL, NULL,
                                           serverinfo_cli_parse_cb, NULL)) {
            BIO_printf(bio_err,
F
FdaSilvaYY 已提交
1896 1897
                       "Warning: Unable to add custom extension %u, skipping\n",
                       serverinfo_types[i]);
M
Matt Caswell 已提交
1898
        }
1899
    }
B
Ben Laurie 已提交
1900

1901 1902
    if (state)
        SSL_CTX_set_info_callback(ctx, apps_ssl_info_callback);
1903

1904
#ifndef OPENSSL_NO_CT
1905 1906 1907
    /* Enable SCT processing, without early connection termination */
    if (ct_validation &&
        !SSL_CTX_enable_ct(ctx, SSL_CT_VALIDATION_PERMISSIVE)) {
1908 1909 1910 1911
        ERR_print_errors(bio_err);
        goto end;
    }

1912
    if (!ctx_set_ctlog_list_file(ctx, ctlog_file)) {
1913
        if (ct_validation) {
1914 1915 1916 1917 1918 1919 1920 1921 1922 1923 1924
            ERR_print_errors(bio_err);
            goto end;
        }

        /*
         * If CT validation is not enabled, the log list isn't needed so don't
         * show errors or abort. We try to load it regardless because then we
         * can show the names of the logs any SCTs came from (SCTs may be seen
         * even with validation disabled).
         */
        ERR_clear_error();
1925 1926 1927
    }
#endif

1928
    SSL_CTX_set_verify(ctx, verify, verify_callback);
1929

1930
    if (!ctx_set_verify_locations(ctx, CAfile, CApath, noCAfile, noCApath)) {
1931
        ERR_print_errors(bio_err);
1932
        goto end;
1933
    }
1934

1935
    ssl_ctx_add_crls(ctx, crls, crl_download);
1936

1937 1938
    if (!set_cert_key_stuff(ctx, cert, key, chain, build_chain))
        goto end;
1939

1940
    if (!noservername) {
1941 1942 1943 1944 1945 1946 1947 1948 1949 1950 1951 1952 1953 1954 1955 1956 1957 1958 1959 1960 1961
        tlsextcbp.biodebug = bio_err;
        SSL_CTX_set_tlsext_servername_callback(ctx, ssl_servername_cb);
        SSL_CTX_set_tlsext_servername_arg(ctx, &tlsextcbp);
    }
# ifndef OPENSSL_NO_SRP
    if (srp_arg.srplogin) {
        if (!srp_lateuser && !SSL_CTX_set_srp_username(ctx, srp_arg.srplogin)) {
            BIO_printf(bio_err, "Unable to set SRP username\n");
            goto end;
        }
        srp_arg.msg = c_msg;
        srp_arg.debug = c_debug;
        SSL_CTX_set_srp_cb_arg(ctx, &srp_arg);
        SSL_CTX_set_srp_client_pwd_callback(ctx, ssl_give_srp_client_pwd_cb);
        SSL_CTX_set_srp_strength(ctx, srp_arg.strength);
        if (c_msg || c_debug || srp_arg.amp == 0)
            SSL_CTX_set_srp_verify_param_callback(ctx,
                                                  ssl_srp_verify_param_cb);
    }
# endif

V
Viktor Dukhovni 已提交
1962 1963 1964
    if (dane_tlsa_domain != NULL) {
        if (SSL_CTX_dane_enable(ctx) <= 0) {
            BIO_printf(bio_err,
F
FdaSilvaYY 已提交
1965 1966
                       "%s: Error enabling DANE TLSA authentication.\n",
                       prog);
V
Viktor Dukhovni 已提交
1967 1968 1969 1970 1971
            ERR_print_errors(bio_err);
            goto end;
        }
    }

1972 1973 1974 1975 1976
    /*
     * In TLSv1.3 NewSessionTicket messages arrive after the handshake and can
     * come at any time. Therefore we use a callback to write out the session
     * when we know about it. This approach works for < TLSv1.3 as well.
     */
1977 1978 1979
    SSL_CTX_set_session_cache_mode(ctx, SSL_SESS_CACHE_CLIENT
                                        | SSL_SESS_CACHE_NO_INTERNAL_STORE);
    SSL_CTX_sess_set_new_cb(ctx, new_session_cb);
1980

1981 1982 1983
    if (set_keylog_file(ctx, keylog_file))
        goto end;

1984
    con = SSL_new(ctx);
1985 1986 1987
    if (con == NULL)
        goto end;

1988 1989
    if (enable_pha)
        SSL_set_post_handshake_auth(con, 1);
1990

1991
    if (sess_in != NULL) {
1992 1993
        SSL_SESSION *sess;
        BIO *stmp = BIO_new_file(sess_in, "r");
1994
        if (stmp == NULL) {
1995 1996 1997 1998 1999 2000
            BIO_printf(bio_err, "Can't open session file %s\n", sess_in);
            ERR_print_errors(bio_err);
            goto end;
        }
        sess = PEM_read_bio_SSL_SESSION(stmp, NULL, 0, NULL);
        BIO_free(stmp);
2001
        if (sess == NULL) {
2002 2003 2004 2005
            BIO_printf(bio_err, "Can't open session file %s\n", sess_in);
            ERR_print_errors(bio_err);
            goto end;
        }
V
Viktor Dukhovni 已提交
2006
        if (!SSL_set_session(con, sess)) {
M
Matt Caswell 已提交
2007 2008 2009 2010
            BIO_printf(bio_err, "Can't set session\n");
            ERR_print_errors(bio_err);
            goto end;
        }
2011

2012 2013 2014 2015 2016
        SSL_SESSION_free(sess);
    }

    if (fallback_scsv)
        SSL_set_mode(con, SSL_MODE_SEND_FALLBACK_SCSV);
B
Bodo Moeller 已提交
2017

2018
    if (!noservername && (servername != NULL || dane_tlsa_domain == NULL)) {
2019 2020 2021 2022 2023
        if (servername == NULL) {
            if(host == NULL || is_dNS_name(host)) 
                servername = (host == NULL) ? "localhost" : host;
        }
        if (servername != NULL && !SSL_set_tlsext_host_name(con, servername)) {
2024 2025 2026 2027 2028
            BIO_printf(bio_err, "Unable to set TLS servername extension.\n");
            ERR_print_errors(bio_err);
            goto end;
        }
    }
2029

V
Viktor Dukhovni 已提交
2030 2031 2032 2033 2034 2035 2036 2037 2038
    if (dane_tlsa_domain != NULL) {
        if (SSL_dane_enable(con, dane_tlsa_domain) <= 0) {
            BIO_printf(bio_err, "%s: Error enabling DANE TLSA "
                       "authentication.\n", prog);
            ERR_print_errors(bio_err);
            goto end;
        }
        if (dane_tlsa_rrset == NULL) {
            BIO_printf(bio_err, "%s: DANE TLSA authentication requires at "
2039
                       "least one -dane_tlsa_rrdata option.\n", prog);
V
Viktor Dukhovni 已提交
2040 2041 2042 2043 2044 2045 2046
            goto end;
        }
        if (tlsa_import_rrset(con, dane_tlsa_rrset) <= 0) {
            BIO_printf(bio_err, "%s: Failed to import any TLSA "
                       "records.\n", prog);
            goto end;
        }
2047 2048
        if (dane_ee_no_name)
            SSL_dane_set_flags(con, DANE_FLAG_NO_DANE_EE_NAMECHECKS);
V
Viktor Dukhovni 已提交
2049
    } else if (dane_tlsa_rrset != NULL) {
2050 2051 2052
        BIO_printf(bio_err, "%s: DANE TLSA authentication requires the "
                   "-dane_tlsa_domain option.\n", prog);
        goto end;
V
Viktor Dukhovni 已提交
2053 2054
    }

2055
 re_start:
2056 2057
    if (init_client(&s, host, port, bindhost, bindport, socket_family,
                    socket_type, protocol) == 0) {
2058
        BIO_printf(bio_err, "connect:errno=%d\n", get_last_socket_error());
R
Rich Salz 已提交
2059
        BIO_closesocket(s);
2060 2061 2062
        goto end;
    }
    BIO_printf(bio_c_out, "CONNECTED(%08X)\n", s);
2063

2064
    if (c_nbio) {
R
Rich Salz 已提交
2065
        if (!BIO_socket_nbio(s, 1)) {
2066 2067 2068
            ERR_print_errors(bio_err);
            goto end;
        }
R
Rich Salz 已提交
2069
        BIO_printf(bio_c_out, "Turned on non blocking io\n");
2070
    }
M
Matt Caswell 已提交
2071
#ifndef OPENSSL_NO_DTLS
M
Matt Caswell 已提交
2072
    if (isdtls) {
2073
        union BIO_sock_info_u peer_info;
2074

M
Matt Caswell 已提交
2075 2076 2077 2078 2079 2080 2081
#ifndef OPENSSL_NO_SCTP
        if (protocol == IPPROTO_SCTP)
            sbio = BIO_new_dgram_sctp(s, BIO_NOCLOSE);
        else
#endif
            sbio = BIO_new_dgram(s, BIO_NOCLOSE);

2082 2083 2084
        if ((peer_info.addr = BIO_ADDR_new()) == NULL) {
            BIO_printf(bio_err, "memory allocation failure\n");
            BIO_closesocket(s);
R
Richard Levitte 已提交
2085
            goto end;
2086 2087
        }
        if (!BIO_sock_info(s, BIO_SOCK_INFO_ADDRESS, &peer_info)) {
2088 2089
            BIO_printf(bio_err, "getsockname:errno=%d\n",
                       get_last_socket_error());
2090
            BIO_ADDR_free(peer_info.addr);
R
Rich Salz 已提交
2091
            BIO_closesocket(s);
2092 2093 2094
            goto end;
        }

2095 2096 2097
        (void)BIO_ctrl_set_connected(sbio, peer_info.addr);
        BIO_ADDR_free(peer_info.addr);
        peer_info.addr = NULL;
2098 2099 2100 2101 2102 2103 2104 2105 2106 2107 2108 2109 2110 2111 2112 2113 2114 2115 2116 2117 2118 2119 2120 2121

        if (enable_timeouts) {
            timeout.tv_sec = 0;
            timeout.tv_usec = DGRAM_RCV_TIMEOUT;
            BIO_ctrl(sbio, BIO_CTRL_DGRAM_SET_RECV_TIMEOUT, 0, &timeout);

            timeout.tv_sec = 0;
            timeout.tv_usec = DGRAM_SND_TIMEOUT;
            BIO_ctrl(sbio, BIO_CTRL_DGRAM_SET_SEND_TIMEOUT, 0, &timeout);
        }

        if (socket_mtu) {
            if (socket_mtu < DTLS_get_link_min_mtu(con)) {
                BIO_printf(bio_err, "MTU too small. Must be at least %ld\n",
                           DTLS_get_link_min_mtu(con));
                BIO_free(sbio);
                goto shut;
            }
            SSL_set_options(con, SSL_OP_NO_QUERY_MTU);
            if (!DTLS_set_link_mtu(con, socket_mtu)) {
                BIO_printf(bio_err, "Failed to set MTU\n");
                BIO_free(sbio);
                goto shut;
            }
2122
        } else {
2123 2124
            /* want to do MTU discovery */
            BIO_ctrl(sbio, BIO_CTRL_DGRAM_MTU_DISCOVER, 0, NULL);
2125
        }
2126
    } else
M
Matt Caswell 已提交
2127
#endif /* OPENSSL_NO_DTLS */
2128 2129 2130 2131 2132 2133 2134 2135 2136 2137 2138 2139 2140 2141
        sbio = BIO_new_socket(s, BIO_NOCLOSE);

    if (nbio_test) {
        BIO *test;

        test = BIO_new(BIO_f_nbio_test());
        sbio = BIO_push(test, sbio);
    }

    if (c_debug) {
        BIO_set_callback(sbio, bio_dump_callback);
        BIO_set_callback_arg(sbio, (char *)bio_c_out);
    }
    if (c_msg) {
2142
#ifndef OPENSSL_NO_SSL_TRACE
2143 2144 2145
        if (c_msg == 2)
            SSL_set_msg_callback(con, SSL_trace);
        else
2146
#endif
2147 2148 2149
            SSL_set_msg_callback(con, msg_cb);
        SSL_set_msg_callback_arg(con, bio_c_msg ? bio_c_msg : bio_c_out);
    }
2150

2151 2152 2153 2154
    if (c_tlsextdebug) {
        SSL_set_tlsext_debug_callback(con, tlsext_cb);
        SSL_set_tlsext_debug_arg(con, bio_c_out);
    }
M
Matt Caswell 已提交
2155
#ifndef OPENSSL_NO_OCSP
2156 2157 2158 2159 2160
    if (c_status_req) {
        SSL_set_tlsext_status_type(con, TLSEXT_STATUSTYPE_ocsp);
        SSL_CTX_set_tlsext_status_cb(ctx, ocsp_resp_cb);
        SSL_CTX_set_tlsext_status_arg(ctx, bio_c_out);
    }
M
Matt Caswell 已提交
2161
#endif
2162 2163 2164 2165 2166

    SSL_set_bio(con, sbio, sbio);
    SSL_set_connect_state(con);

    /* ok, lets connect */
2167 2168
    if (fileno_stdin() > SSL_get_fd(con))
        width = fileno_stdin() + 1;
2169 2170
    else
        width = SSL_get_fd(con) + 1;
2171

2172 2173 2174 2175 2176 2177 2178 2179 2180 2181 2182
    read_tty = 1;
    write_tty = 0;
    tty_on = 0;
    read_ssl = 1;
    write_ssl = 1;

    cbuf_len = 0;
    cbuf_off = 0;
    sbuf_len = 0;
    sbuf_off = 0;

2183 2184 2185
    switch ((PROTOCOL_CHOICE) starttls_proto) {
    case PROTO_OFF:
        break;
2186
    case PROTO_LMTP:
2187 2188 2189 2190 2191 2192 2193 2194 2195 2196 2197 2198
    case PROTO_SMTP:
        {
            /*
             * This is an ugly hack that does a lot of assumptions. We do
             * have to handle multi-line responses which may come in a single
             * packet or not. We therefore have to use BIO_gets() which does
             * need a buffering BIO. So during the initial chitchat we do
             * push a buffering BIO into the chain that is removed again
             * later on to not disturb the rest of the s_client operation.
             */
            int foundit = 0;
            BIO *fbio = BIO_new(BIO_f_buffer());
2199

2200
            BIO_push(fbio, sbio);
2201
            /* Wait for multi-line response to end from LMTP or SMTP */
2202 2203
            do {
                mbuf_len = BIO_gets(fbio, mbuf, BUFSIZZ);
2204
            } while (mbuf_len > 3 && mbuf[3] == '-');
2205 2206
            if (protohost == NULL)
                protohost = "mail.example.com";
2207
            if (starttls_proto == (int)PROTO_LMTP)
2208
                BIO_printf(fbio, "LHLO %s\r\n", protohost);
2209
            else
2210
                BIO_printf(fbio, "EHLO %s\r\n", protohost);
2211
            (void)BIO_flush(fbio);
2212 2213 2214 2215
            /*
             * Wait for multi-line response to end LHLO LMTP or EHLO SMTP
             * response.
             */
2216 2217 2218 2219
            do {
                mbuf_len = BIO_gets(fbio, mbuf, BUFSIZZ);
                if (strstr(mbuf, "STARTTLS"))
                    foundit = 1;
2220
            } while (mbuf_len > 3 && mbuf[3] == '-');
2221 2222 2223 2224 2225
            (void)BIO_flush(fbio);
            BIO_pop(fbio);
            BIO_free(fbio);
            if (!foundit)
                BIO_printf(bio_err,
2226
                           "Didn't find STARTTLS in server response,"
Q
Quanah Gibson-Mount 已提交
2227
                           " trying anyway...\n");
2228 2229
            BIO_printf(sbio, "STARTTLS\r\n");
            BIO_read(sbio, sbuf, BUFSIZZ);
2230
        }
2231 2232 2233 2234 2235 2236 2237 2238 2239 2240
        break;
    case PROTO_POP3:
        {
            BIO_read(sbio, mbuf, BUFSIZZ);
            BIO_printf(sbio, "STLS\r\n");
            mbuf_len = BIO_read(sbio, sbuf, BUFSIZZ);
            if (mbuf_len < 0) {
                BIO_printf(bio_err, "BIO_read failed\n");
                goto end;
            }
2241
        }
2242 2243 2244 2245 2246
        break;
    case PROTO_IMAP:
        {
            int foundit = 0;
            BIO *fbio = BIO_new(BIO_f_buffer());
2247

2248 2249 2250 2251 2252 2253 2254 2255 2256 2257 2258 2259 2260 2261 2262 2263 2264
            BIO_push(fbio, sbio);
            BIO_gets(fbio, mbuf, BUFSIZZ);
            /* STARTTLS command requires CAPABILITY... */
            BIO_printf(fbio, ". CAPABILITY\r\n");
            (void)BIO_flush(fbio);
            /* wait for multi-line CAPABILITY response */
            do {
                mbuf_len = BIO_gets(fbio, mbuf, BUFSIZZ);
                if (strstr(mbuf, "STARTTLS"))
                    foundit = 1;
            }
            while (mbuf_len > 3 && mbuf[0] != '.');
            (void)BIO_flush(fbio);
            BIO_pop(fbio);
            BIO_free(fbio);
            if (!foundit)
                BIO_printf(bio_err,
2265
                           "Didn't find STARTTLS in server response,"
Q
Quanah Gibson-Mount 已提交
2266
                           " trying anyway...\n");
2267 2268
            BIO_printf(sbio, ". STARTTLS\r\n");
            BIO_read(sbio, sbuf, BUFSIZZ);
2269
        }
2270 2271 2272 2273
        break;
    case PROTO_FTP:
        {
            BIO *fbio = BIO_new(BIO_f_buffer());
2274

2275 2276 2277 2278 2279 2280 2281 2282 2283 2284 2285
            BIO_push(fbio, sbio);
            /* wait for multi-line response to end from FTP */
            do {
                mbuf_len = BIO_gets(fbio, mbuf, BUFSIZZ);
            }
            while (mbuf_len > 3 && mbuf[3] == '-');
            (void)BIO_flush(fbio);
            BIO_pop(fbio);
            BIO_free(fbio);
            BIO_printf(sbio, "AUTH TLS\r\n");
            BIO_read(sbio, sbuf, BUFSIZZ);
2286
        }
2287 2288
        break;
    case PROTO_XMPP:
2289
    case PROTO_XMPP_SERVER:
2290
        {
2291 2292 2293
            int seen = 0;
            BIO_printf(sbio, "<stream:stream "
                       "xmlns:stream='http://etherx.jabber.org/streams' "
2294 2295
                       "xmlns='jabber:%s' to='%s' version='1.0'>",
                       starttls_proto == PROTO_XMPP ? "client" : "server",
2296
                       protohost ? protohost : host);
2297
            seen = BIO_read(sbio, mbuf, BUFSIZZ);
2298 2299 2300 2301 2302
            if (seen < 0) {
                BIO_printf(bio_err, "BIO_read failed\n");
                goto end;
            }
            mbuf[seen] = '\0';
2303 2304 2305 2306 2307 2308
            while (!strstr
                   (mbuf, "<starttls xmlns='urn:ietf:params:xml:ns:xmpp-tls'")
                   && !strstr(mbuf,
                              "<starttls xmlns=\"urn:ietf:params:xml:ns:xmpp-tls\""))
            {
                seen = BIO_read(sbio, mbuf, BUFSIZZ);
2309

2310 2311
                if (seen <= 0)
                    goto shut;
2312

2313
                mbuf[seen] = '\0';
2314 2315 2316 2317
            }
            BIO_printf(sbio,
                       "<starttls xmlns='urn:ietf:params:xml:ns:xmpp-tls'/>");
            seen = BIO_read(sbio, sbuf, BUFSIZZ);
2318 2319 2320 2321 2322
            if (seen < 0) {
                BIO_printf(bio_err, "BIO_read failed\n");
                goto shut;
            }
            sbuf[seen] = '\0';
2323 2324
            if (!strstr(sbuf, "<proceed"))
                goto shut;
2325
            mbuf[0] = '\0';
2326
        }
2327
        break;
2328 2329 2330 2331 2332 2333 2334 2335 2336 2337 2338 2339 2340 2341 2342 2343 2344 2345 2346 2347 2348 2349 2350 2351 2352 2353 2354 2355 2356
    case PROTO_TELNET:
        {
            static const unsigned char tls_do[] = {
                /* IAC    DO   START_TLS */
                   255,   253, 46
            };
            static const unsigned char tls_will[] = {
                /* IAC  WILL START_TLS */
                   255, 251, 46
            };
            static const unsigned char tls_follows[] = {
                /* IAC  SB   START_TLS FOLLOWS IAC  SE */
                   255, 250, 46,       1,      255, 240
            };
            int bytes;

            /* Telnet server should demand we issue START_TLS */
            bytes = BIO_read(sbio, mbuf, BUFSIZZ);
            if (bytes != 3 || memcmp(mbuf, tls_do, 3) != 0)
                goto shut;
            /* Agree to issue START_TLS and send the FOLLOWS sub-command */
            BIO_write(sbio, tls_will, 3);
            BIO_write(sbio, tls_follows, 6);
            (void)BIO_flush(sbio);
            /* Telnet server also sent the FOLLOWS sub-command */
            bytes = BIO_read(sbio, mbuf, BUFSIZZ);
            if (bytes != 6 || memcmp(mbuf, tls_follows, 6) != 0)
                goto shut;
        }
2357 2358 2359
        break;
    case PROTO_CONNECT:
        {
2360 2361 2362 2363 2364
            enum {
                error_proto,     /* Wrong protocol, not even HTTP */
                error_connect,   /* CONNECT failed */
                success
            } foundit = error_connect;
2365 2366 2367
            BIO *fbio = BIO_new(BIO_f_buffer());

            BIO_push(fbio, sbio);
2368
            BIO_printf(fbio, "CONNECT %s HTTP/1.0\r\n", connectstr);
2369
            /*
2370 2371 2372 2373 2374 2375 2376 2377 2378 2379 2380 2381 2382 2383
             * Workaround for broken proxies which would otherwise close
             * the connection when entering tunnel mode (eg Squid 2.6)
             */
            BIO_printf(fbio, "Proxy-Connection: Keep-Alive\r\n");

            /* Support for basic (base64) proxy authentication */
            if (proxyuser != NULL) {
                size_t l;
                char *proxyauth, *proxyauthenc;

                l = strlen(proxyuser);
                if (proxypass != NULL)
                    l += strlen(proxypass);
                proxyauth = app_malloc(l + 2, "Proxy auth string");
2384 2385
                BIO_snprintf(proxyauth, l + 2, "%s:%s", proxyuser,
                             (proxypass != NULL) ? proxypass : "");
2386
                proxyauthenc = base64encode(proxyauth, strlen(proxyauth));
2387 2388
                BIO_printf(fbio, "Proxy-Authorization: Basic %s\r\n",
                           proxyauthenc);
2389 2390 2391 2392 2393 2394
                OPENSSL_clear_free(proxyauth, strlen(proxyauth));
                OPENSSL_clear_free(proxyauthenc, strlen(proxyauthenc));
            }

            /* Terminate the HTTP CONNECT request */
            BIO_printf(fbio, "\r\n");
2395
            (void)BIO_flush(fbio);
2396 2397 2398 2399 2400 2401 2402
            /*
             * The first line is the HTTP response.  According to RFC 7230,
             * it's formated exactly like this:
             *
             * HTTP/d.d ddd Reason text\r\n
             */
            mbuf_len = BIO_gets(fbio, mbuf, BUFSIZZ);
2403 2404 2405 2406 2407 2408 2409 2410 2411
            if (mbuf_len < (int)strlen("HTTP/1.0 200")) {
                BIO_printf(bio_err,
                           "%s: HTTP CONNECT failed, insufficient response "
                           "from proxy (got %d octets)\n", prog, mbuf_len);
                (void)BIO_flush(fbio);
                BIO_pop(fbio);
                BIO_free(fbio);
                goto shut;
            }
2412 2413 2414 2415 2416 2417 2418 2419 2420 2421 2422 2423 2424 2425 2426 2427 2428
            if (mbuf[8] != ' ') {
                BIO_printf(bio_err,
                           "%s: HTTP CONNECT failed, incorrect response "
                           "from proxy\n", prog);
                foundit = error_proto;
            } else if (mbuf[9] != '2') {
                BIO_printf(bio_err, "%s: HTTP CONNECT failed: %s ", prog,
                           &mbuf[9]);
            } else {
                foundit = success;
            }
            if (foundit != error_proto) {
                /* Read past all following headers */
                do {
                    mbuf_len = BIO_gets(fbio, mbuf, BUFSIZZ);
                } while (mbuf_len > 2);
            }
2429 2430 2431
            (void)BIO_flush(fbio);
            BIO_pop(fbio);
            BIO_free(fbio);
2432
            if (foundit != success) {
2433 2434 2435 2436
                goto shut;
            }
        }
        break;
2437 2438 2439 2440 2441 2442 2443 2444 2445 2446 2447 2448 2449 2450 2451 2452 2453 2454 2455 2456 2457 2458 2459 2460 2461 2462 2463 2464 2465 2466 2467 2468 2469 2470 2471 2472 2473 2474 2475 2476 2477 2478 2479 2480 2481 2482 2483 2484 2485 2486 2487 2488 2489 2490 2491 2492 2493 2494 2495 2496 2497
    case PROTO_IRC:
        {
            int numeric;
            BIO *fbio = BIO_new(BIO_f_buffer());

            BIO_push(fbio, sbio);
            BIO_printf(fbio, "STARTTLS\r\n");
            (void)BIO_flush(fbio);
            width = SSL_get_fd(con) + 1;

            do {
                numeric = 0;

                FD_ZERO(&readfds);
                openssl_fdset(SSL_get_fd(con), &readfds);
                timeout.tv_sec = S_CLIENT_IRC_READ_TIMEOUT;
                timeout.tv_usec = 0;
                /*
                 * If the IRCd doesn't respond within
                 * S_CLIENT_IRC_READ_TIMEOUT seconds, assume
                 * it doesn't support STARTTLS. Many IRCds
                 * will not give _any_ sort of response to a
                 * STARTTLS command when it's not supported.
                 */
                if (!BIO_get_buffer_num_lines(fbio)
                    && !BIO_pending(fbio)
                    && !BIO_pending(sbio)
                    && select(width, (void *)&readfds, NULL, NULL,
                              &timeout) < 1) {
                    BIO_printf(bio_err,
                               "Timeout waiting for response (%d seconds).\n",
                               S_CLIENT_IRC_READ_TIMEOUT);
                    break;
                }

                mbuf_len = BIO_gets(fbio, mbuf, BUFSIZZ);
                if (mbuf_len < 1 || sscanf(mbuf, "%*s %d", &numeric) != 1)
                    break;
                /* :example.net 451 STARTTLS :You have not registered */
                /* :example.net 421 STARTTLS :Unknown command */
                if ((numeric == 451 || numeric == 421)
                    && strstr(mbuf, "STARTTLS") != NULL) {
                    BIO_printf(bio_err, "STARTTLS not supported: %s", mbuf);
                    break;
                }
                if (numeric == 691) {
                    BIO_printf(bio_err, "STARTTLS negotiation failed: ");
                    ERR_print_errors(bio_err);
                    break;
                }
            } while (numeric != 670);

            (void)BIO_flush(fbio);
            BIO_pop(fbio);
            BIO_free(fbio);
            if (numeric != 670) {
                BIO_printf(bio_err, "Server does not support STARTTLS.\n");
                ret = 1;
                goto shut;
            }
        }
V
Valentin Vidic 已提交
2498
        break;
K
Keigo Tanaka 已提交
2499 2500 2501 2502 2503 2504 2505 2506 2507 2508 2509 2510 2511 2512 2513 2514 2515 2516 2517 2518 2519 2520 2521 2522 2523 2524 2525 2526 2527 2528 2529 2530 2531 2532 2533 2534 2535 2536 2537 2538 2539 2540 2541 2542 2543 2544 2545 2546 2547 2548 2549 2550 2551 2552 2553
    case PROTO_MYSQL:
        {
            /* SSL request packet */
            static const unsigned char ssl_req[] = {
                /* payload_length,   sequence_id */
                   0x20, 0x00, 0x00, 0x01,
                /* payload */
                /* capability flags, CLIENT_SSL always set */
                   0x85, 0xae, 0x7f, 0x00,
                /* max-packet size */
                   0x00, 0x00, 0x00, 0x01,
                /* character set */
                   0x21,
                /* string[23] reserved (all [0]) */
                   0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
                   0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00,
                   0x00, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00
            };
            int bytes = 0;
            int ssl_flg = 0x800;
            int pos;
            const unsigned char *packet = (const unsigned char *)sbuf;

            /* Receiving Initial Handshake packet. */
            bytes = BIO_read(sbio, (void *)packet, BUFSIZZ);
            if (bytes < 0) {
                BIO_printf(bio_err, "BIO_read failed\n");
                goto shut;
            /* Packet length[3], Packet number[1] + minimum payload[17] */
            } else if (bytes < 21) {
                BIO_printf(bio_err, "MySQL packet too short.\n");
                goto shut;
            } else if (bytes != (4 + packet[0] +
                                 (packet[1] << 8) +
                                 (packet[2] << 16))) {
                BIO_printf(bio_err, "MySQL packet length does not match.\n");
                goto shut;
            /* protocol version[1] */
            } else if (packet[4] != 0xA) {
                BIO_printf(bio_err,
                           "Only MySQL protocol version 10 is supported.\n");
                goto shut;
            }

            pos = 5;
            /* server version[string+NULL] */
            for (;;) {
                if (pos >= bytes) {
                    BIO_printf(bio_err, "Cannot confirm server version. ");
                    goto shut;
                } else if (packet[pos++] == '\0') {
                    break;
                }
            }

2554
            /* make sure we have at least 15 bytes left in the packet */
K
Keigo Tanaka 已提交
2555 2556 2557 2558 2559 2560 2561 2562 2563 2564 2565 2566 2567 2568 2569 2570 2571 2572 2573 2574 2575 2576 2577 2578
            if (pos + 15 > bytes) {
                BIO_printf(bio_err,
                           "MySQL server handshake packet is broken.\n");
                goto shut;
            }

            pos += 12; /* skip over conn id[4] + SALT[8] */
            if (packet[pos++] != '\0') { /* verify filler */
                BIO_printf(bio_err,
                           "MySQL packet is broken.\n");
                goto shut;
            }

            /* capability flags[2] */
            if (!((packet[pos] + (packet[pos + 1] << 8)) & ssl_flg)) {
                BIO_printf(bio_err, "MySQL server does not support SSL.\n");
                goto shut;
            }

            /* Sending SSL Handshake packet. */
            BIO_write(sbio, ssl_req, sizeof(ssl_req));
            (void)BIO_flush(sbio);
        }
        break;
V
Valentin Vidic 已提交
2579 2580 2581 2582 2583 2584 2585 2586 2587 2588 2589 2590 2591 2592 2593 2594 2595 2596
    case PROTO_POSTGRES:
        {
            static const unsigned char ssl_request[] = {
                /* Length        SSLRequest */
                   0, 0, 0, 8,   4, 210, 22, 47
            };
            int bytes;

            /* Send SSLRequest packet */
            BIO_write(sbio, ssl_request, 8);
            (void)BIO_flush(sbio);

            /* Reply will be a single S if SSL is enabled */
            bytes = BIO_read(sbio, sbuf, BUFSIZZ);
            if (bytes != 1 || sbuf[0] != 'S')
                goto shut;
        }
        break;
2597 2598 2599 2600 2601 2602 2603 2604 2605 2606
    case PROTO_NNTP:
        {
            int foundit = 0;
            BIO *fbio = BIO_new(BIO_f_buffer());

            BIO_push(fbio, sbio);
            BIO_gets(fbio, mbuf, BUFSIZZ);
            /* STARTTLS command requires CAPABILITIES... */
            BIO_printf(fbio, "CAPABILITIES\r\n");
            (void)BIO_flush(fbio);
2607 2608 2609 2610 2611 2612 2613 2614 2615 2616
            BIO_gets(fbio, mbuf, BUFSIZZ);
            /* no point in trying to parse the CAPABILITIES response if there is none */
            if (strstr(mbuf, "101") != NULL) {
                /* wait for multi-line CAPABILITIES response */
                do {
                    mbuf_len = BIO_gets(fbio, mbuf, BUFSIZZ);
                    if (strstr(mbuf, "STARTTLS"))
                        foundit = 1;
                } while (mbuf_len > 1 && mbuf[0] != '.');
            }
2617 2618 2619 2620 2621 2622 2623 2624
            (void)BIO_flush(fbio);
            BIO_pop(fbio);
            BIO_free(fbio);
            if (!foundit)
                BIO_printf(bio_err,
                           "Didn't find STARTTLS in server response,"
                           " trying anyway...\n");
            BIO_printf(sbio, "STARTTLS\r\n");
2625 2626 2627 2628 2629 2630 2631 2632 2633 2634
            mbuf_len = BIO_read(sbio, mbuf, BUFSIZZ);
            if (mbuf_len < 0) {
                BIO_printf(bio_err, "BIO_read failed\n");
                goto end;
            }
            mbuf[mbuf_len] = '\0';
            if (strstr(mbuf, "382") == NULL) {
                BIO_printf(bio_err, "STARTTLS failed: %s", mbuf);
                goto shut;
            }
2635 2636
        }
        break;
2637 2638 2639 2640 2641 2642 2643 2644 2645 2646 2647 2648 2649 2650 2651 2652 2653 2654 2655 2656 2657 2658 2659 2660 2661 2662 2663 2664 2665 2666 2667
    case PROTO_SIEVE:
        {
            int foundit = 0;
            BIO *fbio = BIO_new(BIO_f_buffer());

            BIO_push(fbio, sbio);
            /* wait for multi-line response to end from Sieve */
            do {
                mbuf_len = BIO_gets(fbio, mbuf, BUFSIZZ);
                /*
                 * According to RFC 5804 § 1.7, capability
                 * is case-insensitive, make it uppercase
                 */
                if (mbuf_len > 1 && mbuf[0] == '"') {
                    make_uppercase(mbuf);
                    if (strncmp(mbuf, "\"STARTTLS\"", 10) == 0)
                        foundit = 1;
                }
            } while (mbuf_len > 1 && mbuf[0] == '"');
            (void)BIO_flush(fbio);
            BIO_pop(fbio);
            BIO_free(fbio);
            if (!foundit)
                BIO_printf(bio_err,
                           "Didn't find STARTTLS in server response,"
                           " trying anyway...\n");
            BIO_printf(sbio, "STARTTLS\r\n");
            mbuf_len = BIO_read(sbio, mbuf, BUFSIZZ);
            if (mbuf_len < 0) {
                BIO_printf(bio_err, "BIO_read failed\n");
                goto end;
2668 2669 2670 2671
            }
            mbuf[mbuf_len] = '\0';
            if (mbuf_len < 2) {
                BIO_printf(bio_err, "STARTTLS failed: %s", mbuf);
2672 2673 2674 2675 2676 2677 2678 2679 2680 2681 2682 2683 2684 2685
                goto shut;
            }
            /*
             * According to RFC 5804 § 2.2, response codes are case-
             * insensitive, make it uppercase but preserve the response.
             */
            strncpy(sbuf, mbuf, 2);
            make_uppercase(sbuf);
            if (strncmp(sbuf, "OK", 2) != 0) {
                BIO_printf(bio_err, "STARTTLS not supported: %s", mbuf);
                goto shut;
            }
        }
        break;
2686 2687 2688 2689 2690 2691 2692 2693 2694 2695 2696 2697 2698 2699 2700 2701 2702 2703 2704 2705 2706 2707 2708 2709 2710 2711 2712 2713 2714 2715 2716 2717 2718 2719 2720 2721 2722 2723 2724 2725 2726 2727 2728 2729 2730 2731 2732 2733 2734 2735 2736 2737 2738 2739 2740 2741 2742 2743 2744 2745 2746 2747 2748 2749 2750 2751 2752 2753 2754
    case PROTO_LDAP:
        {
            /* StartTLS Operation according to RFC 4511 */
            static char ldap_tls_genconf[] = "asn1=SEQUENCE:LDAPMessage\n"
                "[LDAPMessage]\n"
                "messageID=INTEGER:1\n"
                "extendedReq=EXPLICIT:23A,IMPLICIT:0C,"
                "FORMAT:ASCII,OCT:1.3.6.1.4.1.1466.20037\n";
            long errline = -1;
            char *genstr = NULL;
            int result = -1;
            ASN1_TYPE *atyp = NULL;
            BIO *ldapbio = BIO_new(BIO_s_mem());
            CONF *cnf = NCONF_new(NULL);

            if (cnf == NULL) {
                BIO_free(ldapbio);
                goto end;
            }
            BIO_puts(ldapbio, ldap_tls_genconf);
            if (NCONF_load_bio(cnf, ldapbio, &errline) <= 0) {
                BIO_free(ldapbio);
                NCONF_free(cnf);
                if (errline <= 0) {
                    BIO_printf(bio_err, "NCONF_load_bio failed\n");
                    goto end;
                } else {
                    BIO_printf(bio_err, "Error on line %ld\n", errline);
                    goto end;
                }
            }
            BIO_free(ldapbio);
            genstr = NCONF_get_string(cnf, "default", "asn1");
            if (genstr == NULL) {
                NCONF_free(cnf);
                BIO_printf(bio_err, "NCONF_get_string failed\n");
                goto end;
            }
            atyp = ASN1_generate_nconf(genstr, cnf);
            if (atyp == NULL) {
                NCONF_free(cnf);
                BIO_printf(bio_err, "ASN1_generate_nconf failed\n");
                goto end;
            }
            NCONF_free(cnf);

            /* Send SSLRequest packet */
            BIO_write(sbio, atyp->value.sequence->data,
                      atyp->value.sequence->length);
            (void)BIO_flush(sbio);
            ASN1_TYPE_free(atyp);

            mbuf_len = BIO_read(sbio, mbuf, BUFSIZZ);
            if (mbuf_len < 0) {
                BIO_printf(bio_err, "BIO_read failed\n");
                goto end;
            }
            result = ldap_ExtendedResponse_parse(mbuf, mbuf_len);
            if (result < 0) {
                BIO_printf(bio_err, "ldap_ExtendedResponse_parse failed\n");
                goto shut;
            } else if (result > 0) {
                BIO_printf(bio_err, "STARTTLS failed, LDAP Result Code: %i\n",
                           result);
                goto shut;
            }
            mbuf_len = 0;
        }
        break;
2755 2756
    }

2757
    if (early_data_file != NULL
2758 2759 2760 2761
            && ((SSL_get0_session(con) != NULL
                 && SSL_SESSION_get_max_early_data(SSL_get0_session(con)) > 0)
                || (psksess != NULL
                    && SSL_SESSION_get_max_early_data(psksess) > 0))) {
2762 2763 2764 2765 2766 2767 2768 2769 2770 2771 2772 2773 2774
        BIO *edfile = BIO_new_file(early_data_file, "r");
        size_t readbytes, writtenbytes;
        int finish = 0;

        if (edfile == NULL) {
            BIO_printf(bio_err, "Cannot open early data file\n");
            goto shut;
        }

        while (!finish) {
            if (!BIO_read_ex(edfile, cbuf, BUFSIZZ, &readbytes))
                finish = 1;

2775
            while (!SSL_write_early_data(con, cbuf, readbytes, &writtenbytes)) {
2776 2777 2778 2779 2780 2781 2782 2783 2784
                switch (SSL_get_error(con, 0)) {
                case SSL_ERROR_WANT_WRITE:
                case SSL_ERROR_WANT_ASYNC:
                case SSL_ERROR_WANT_READ:
                    /* Just keep trying - busy waiting */
                    continue;
                default:
                    BIO_printf(bio_err, "Error writing early data\n");
                    BIO_free(edfile);
2785
                    ERR_print_errors(bio_err);
2786 2787 2788 2789 2790 2791 2792 2793
                    goto shut;
                }
            }
        }

        BIO_free(edfile);
    }

2794 2795 2796 2797
    for (;;) {
        FD_ZERO(&readfds);
        FD_ZERO(&writefds);

2798
        if (SSL_is_dtls(con) && DTLSv1_get_timeout(con, &timeout))
2799 2800 2801 2802
            timeoutp = &timeout;
        else
            timeoutp = NULL;

M
Matt Caswell 已提交
2803
        if (!SSL_is_init_finished(con) && SSL_total_renegotiations(con) == 0
2804
                && SSL_get_key_update_type(con) == SSL_KEY_UPDATE_NONE) {
2805 2806 2807 2808 2809 2810
            in_init = 1;
            tty_on = 0;
        } else {
            tty_on = 1;
            if (in_init) {
                in_init = 0;
2811

2812 2813
                if (c_brief) {
                    BIO_puts(bio_err, "CONNECTION ESTABLISHED\n");
R
Rich Salz 已提交
2814
                    print_ssl_summary(con);
2815 2816
                }

R
Rob Percival 已提交
2817
                print_stuff(bio_c_out, con, full_log);
2818 2819 2820 2821
                if (full_log > 0)
                    full_log--;

                if (starttls_proto) {
2822
                    BIO_write(bio_err, mbuf, mbuf_len);
2823
                    /* We don't need to know any more */
2824 2825
                    if (!reconnect)
                        starttls_proto = PROTO_OFF;
2826 2827 2828 2829 2830 2831
                }

                if (reconnect) {
                    reconnect--;
                    BIO_printf(bio_c_out,
                               "drop connection and then reconnect\n");
M
Matt Caswell 已提交
2832
                    do_ssl_shutdown(con);
2833
                    SSL_set_connect_state(con);
R
Rich Salz 已提交
2834
                    BIO_closesocket(SSL_get_fd(con));
2835 2836 2837 2838 2839
                    goto re_start;
                }
            }
        }

2840
        ssl_pending = read_ssl && SSL_has_pending(con);
2841 2842

        if (!ssl_pending) {
R
Rich Salz 已提交
2843
#if !defined(OPENSSL_SYS_WINDOWS) && !defined(OPENSSL_SYS_MSDOS)
2844
            if (tty_on) {
2845 2846 2847 2848 2849 2850
                /*
                 * Note that select() returns when read _would not block_,
                 * and EOF satisfies that.  To avoid a CPU-hogging loop,
                 * set the flag so we exit.
                 */
                if (read_tty && !at_eof)
2851 2852
                    openssl_fdset(fileno_stdin(), &readfds);
#if !defined(OPENSSL_SYS_VMS)
2853
                if (write_tty)
2854
                    openssl_fdset(fileno_stdout(), &writefds);
2855
#endif
2856 2857 2858 2859 2860
            }
            if (read_ssl)
                openssl_fdset(SSL_get_fd(con), &readfds);
            if (write_ssl)
                openssl_fdset(SSL_get_fd(con), &writefds);
2861
#else
2862 2863 2864 2865 2866 2867 2868 2869 2870 2871 2872 2873 2874 2875 2876
            if (!tty_on || !write_tty) {
                if (read_ssl)
                    openssl_fdset(SSL_get_fd(con), &readfds);
                if (write_ssl)
                    openssl_fdset(SSL_get_fd(con), &writefds);
            }
#endif

            /*
             * Note: under VMS with SOCKETSHR the second parameter is
             * currently of type (int *) whereas under other systems it is
             * (void *) if you don't have a cast it will choke the compiler:
             * if you do have a cast then you can either go for (int *) or
             * (void *).
             */
2877
#if defined(OPENSSL_SYS_WINDOWS) || defined(OPENSSL_SYS_MSDOS)
2878 2879 2880 2881 2882 2883 2884 2885 2886 2887 2888 2889 2890 2891
            /*
             * Under Windows/DOS we make the assumption that we can always
             * write to the tty: therefore if we need to write to the tty we
             * just fall through. Otherwise we timeout the select every
             * second and see if there are any keypresses. Note: this is a
             * hack, in a proper Windows application we wouldn't do this.
             */
            i = 0;
            if (!write_tty) {
                if (read_tty) {
                    tv.tv_sec = 1;
                    tv.tv_usec = 0;
                    i = select(width, (void *)&readfds, (void *)&writefds,
                               NULL, &tv);
2892
                    if (!i && (!has_stdin_waiting() || !read_tty))
2893 2894 2895 2896 2897
                        continue;
                } else
                    i = select(width, (void *)&readfds, (void *)&writefds,
                               NULL, timeoutp);
            }
2898
#else
2899 2900 2901 2902 2903 2904 2905 2906 2907 2908
            i = select(width, (void *)&readfds, (void *)&writefds,
                       NULL, timeoutp);
#endif
            if (i < 0) {
                BIO_printf(bio_err, "bad select %d\n",
                           get_last_socket_error());
                goto shut;
            }
        }

2909
        if (SSL_is_dtls(con) && DTLSv1_handle_timeout(con) > 0)
2910 2911 2912 2913 2914 2915 2916 2917 2918 2919 2920 2921 2922 2923 2924 2925 2926 2927 2928 2929 2930 2931 2932 2933 2934
            BIO_printf(bio_err, "TIMEOUT occurred\n");

        if (!ssl_pending && FD_ISSET(SSL_get_fd(con), &writefds)) {
            k = SSL_write(con, &(cbuf[cbuf_off]), (unsigned int)cbuf_len);
            switch (SSL_get_error(con, k)) {
            case SSL_ERROR_NONE:
                cbuf_off += k;
                cbuf_len -= k;
                if (k <= 0)
                    goto end;
                /* we have done a  write(con,NULL,0); */
                if (cbuf_len <= 0) {
                    read_tty = 1;
                    write_ssl = 0;
                } else {        /* if (cbuf_len > 0) */

                    read_tty = 0;
                    write_ssl = 1;
                }
                break;
            case SSL_ERROR_WANT_WRITE:
                BIO_printf(bio_c_out, "write W BLOCK\n");
                write_ssl = 1;
                read_tty = 0;
                break;
2935 2936
            case SSL_ERROR_WANT_ASYNC:
                BIO_printf(bio_c_out, "write A BLOCK\n");
2937
                wait_for_async(con);
2938 2939 2940
                write_ssl = 1;
                read_tty = 0;
                break;
2941 2942 2943 2944 2945 2946 2947 2948 2949 2950 2951 2952 2953 2954 2955 2956 2957 2958 2959 2960 2961 2962 2963 2964 2965 2966 2967 2968 2969 2970
            case SSL_ERROR_WANT_READ:
                BIO_printf(bio_c_out, "write R BLOCK\n");
                write_tty = 0;
                read_ssl = 1;
                write_ssl = 0;
                break;
            case SSL_ERROR_WANT_X509_LOOKUP:
                BIO_printf(bio_c_out, "write X BLOCK\n");
                break;
            case SSL_ERROR_ZERO_RETURN:
                if (cbuf_len != 0) {
                    BIO_printf(bio_c_out, "shutdown\n");
                    ret = 0;
                    goto shut;
                } else {
                    read_tty = 1;
                    write_ssl = 0;
                    break;
                }

            case SSL_ERROR_SYSCALL:
                if ((k != 0) || (cbuf_len != 0)) {
                    BIO_printf(bio_err, "write:errno=%d\n",
                               get_last_socket_error());
                    goto shut;
                } else {
                    read_tty = 1;
                    write_ssl = 0;
                }
                break;
M
Matt Caswell 已提交
2971 2972
            case SSL_ERROR_WANT_ASYNC_JOB:
                /* This shouldn't ever happen in s_client - treat as an error */
2973 2974 2975 2976 2977
            case SSL_ERROR_SSL:
                ERR_print_errors(bio_err);
                goto shut;
            }
        }
2978
#if defined(OPENSSL_SYS_WINDOWS) || defined(OPENSSL_SYS_MSDOS) || defined(OPENSSL_SYS_VMS)
2979 2980
        /* Assume Windows/DOS/BeOS can always write */
        else if (!ssl_pending && write_tty)
2981
#else
2982
        else if (!ssl_pending && FD_ISSET(fileno_stdout(), &writefds))
2983
#endif
2984
        {
2985
#ifdef CHARSET_EBCDIC
2986 2987 2988 2989 2990 2991 2992 2993 2994 2995
            ascii2ebcdic(&(sbuf[sbuf_off]), &(sbuf[sbuf_off]), sbuf_len);
#endif
            i = raw_write_stdout(&(sbuf[sbuf_off]), sbuf_len);

            if (i <= 0) {
                BIO_printf(bio_c_out, "DONE\n");
                ret = 0;
                goto shut;
            }

F
FdaSilvaYY 已提交
2996
            sbuf_len -= i;
2997 2998 2999 3000 3001 3002
            sbuf_off += i;
            if (sbuf_len <= 0) {
                read_ssl = 1;
                write_tty = 0;
            }
        } else if (ssl_pending || FD_ISSET(SSL_get_fd(con), &readfds)) {
3003
#ifdef RENEG
3004 3005 3006 3007 3008 3009 3010
            {
                static int iiii;
                if (++iiii == 52) {
                    SSL_renegotiate(con);
                    iiii = 0;
                }
            }
3011
#endif
3012 3013 3014 3015 3016 3017 3018 3019 3020 3021 3022 3023
            k = SSL_read(con, sbuf, 1024 /* BUFSIZZ */ );

            switch (SSL_get_error(con, k)) {
            case SSL_ERROR_NONE:
                if (k <= 0)
                    goto end;
                sbuf_off = 0;
                sbuf_len = k;

                read_ssl = 0;
                write_tty = 1;
                break;
3024 3025
            case SSL_ERROR_WANT_ASYNC:
                BIO_printf(bio_c_out, "read A BLOCK\n");
3026
                wait_for_async(con);
3027 3028 3029 3030 3031
                write_tty = 0;
                read_ssl = 1;
                if ((read_tty == 0) && (write_ssl == 0))
                    write_ssl = 1;
                break;
3032 3033 3034 3035 3036 3037 3038 3039 3040 3041 3042 3043 3044 3045 3046 3047 3048 3049 3050 3051 3052 3053 3054 3055 3056 3057
            case SSL_ERROR_WANT_WRITE:
                BIO_printf(bio_c_out, "read W BLOCK\n");
                write_ssl = 1;
                read_tty = 0;
                break;
            case SSL_ERROR_WANT_READ:
                BIO_printf(bio_c_out, "read R BLOCK\n");
                write_tty = 0;
                read_ssl = 1;
                if ((read_tty == 0) && (write_ssl == 0))
                    write_ssl = 1;
                break;
            case SSL_ERROR_WANT_X509_LOOKUP:
                BIO_printf(bio_c_out, "read X BLOCK\n");
                break;
            case SSL_ERROR_SYSCALL:
                ret = get_last_socket_error();
                if (c_brief)
                    BIO_puts(bio_err, "CONNECTION CLOSED BY SERVER\n");
                else
                    BIO_printf(bio_err, "read:errno=%d\n", ret);
                goto shut;
            case SSL_ERROR_ZERO_RETURN:
                BIO_printf(bio_c_out, "closed\n");
                ret = 0;
                goto shut;
M
Matt Caswell 已提交
3058 3059
            case SSL_ERROR_WANT_ASYNC_JOB:
                /* This shouldn't ever happen in s_client. Treat as an error */
3060 3061 3062 3063 3064
            case SSL_ERROR_SSL:
                ERR_print_errors(bio_err);
                goto shut;
            }
        }
3065 3066 3067
/* OPENSSL_SYS_MSDOS includes OPENSSL_SYS_WINDOWS */
#if defined(OPENSSL_SYS_MSDOS)
        else if (has_stdin_waiting())
3068
#else
3069
        else if (FD_ISSET(fileno_stdin(), &readfds))
3070 3071 3072 3073 3074 3075 3076 3077 3078 3079 3080 3081 3082 3083 3084 3085 3086 3087 3088 3089
#endif
        {
            if (crlf) {
                int j, lf_num;

                i = raw_read_stdin(cbuf, BUFSIZZ / 2);
                lf_num = 0;
                /* both loops are skipped when i <= 0 */
                for (j = 0; j < i; j++)
                    if (cbuf[j] == '\n')
                        lf_num++;
                for (j = i - 1; j >= 0; j--) {
                    cbuf[j + lf_num] = cbuf[j];
                    if (cbuf[j] == '\n') {
                        lf_num--;
                        i++;
                        cbuf[j + lf_num] = '\r';
                    }
                }
                assert(lf_num == 0);
3090
            } else
3091
                i = raw_read_stdin(cbuf, BUFSIZZ);
3092
#if !defined(OPENSSL_SYS_WINDOWS) && !defined(OPENSSL_SYS_MSDOS)
3093 3094
            if (i == 0)
                at_eof = 1;
3095
#endif
3096

R
Rich Salz 已提交
3097
            if ((!c_ign_eof) && ((i <= 0) || (cbuf[0] == 'Q' && cmdletters))) {
3098 3099 3100 3101 3102
                BIO_printf(bio_err, "DONE\n");
                ret = 0;
                goto shut;
            }

R
Rich Salz 已提交
3103
            if ((!c_ign_eof) && (cbuf[0] == 'R' && cmdletters)) {
3104 3105 3106
                BIO_printf(bio_err, "RENEGOTIATING\n");
                SSL_renegotiate(con);
                cbuf_len = 0;
3107
	    } else if (!c_ign_eof && (cbuf[0] == 'K' || cbuf[0] == 'k' )
M
Matt Caswell 已提交
3108
                    && cmdletters) {
3109 3110 3111 3112 3113
                BIO_printf(bio_err, "KEYUPDATE\n");
                SSL_key_update(con,
                               cbuf[0] == 'K' ? SSL_KEY_UPDATE_REQUESTED
                                              : SSL_KEY_UPDATE_NOT_REQUESTED);
                cbuf_len = 0;
R
Richard Levitte 已提交
3114
            } else {
3115 3116
                cbuf_len = i;
                cbuf_off = 0;
3117
#ifdef CHARSET_EBCDIC
3118 3119 3120 3121 3122 3123 3124 3125 3126 3127 3128 3129
                ebcdic2ascii(cbuf, cbuf, i);
#endif
            }

            write_ssl = 1;
            read_tty = 0;
        }
    }

    ret = 0;
 shut:
    if (in_init)
R
Rob Percival 已提交
3130
        print_stuff(bio_c_out, con, full_log);
M
Matt Caswell 已提交
3131
    do_ssl_shutdown(con);
3132

3133 3134 3135 3136 3137 3138 3139 3140 3141 3142 3143
    /*
     * If we ended with an alert being sent, but still with data in the
     * network buffer to be read, then calling BIO_closesocket() will
     * result in a TCP-RST being sent. On some platforms (notably
     * Windows) then this will result in the peer immediately abandoning
     * the connection including any buffered alert data before it has
     * had a chance to be read. Shutting down the sending side first,
     * and then closing the socket sends TCP-FIN first followed by
     * TCP-RST. This seems to allow the peer to read the alert data.
     */
    shutdown(SSL_get_fd(con), 1); /* SHUT_WR */
3144 3145 3146 3147 3148 3149 3150 3151 3152 3153 3154 3155 3156
    /*
     * We just said we have nothing else to say, but it doesn't mean that
     * the other side has nothing. It's even recommended to consume incoming
     * data. [In testing context this ensures that alerts are passed on...]
     */
    timeout.tv_sec = 0;
    timeout.tv_usec = 500000;  /* some extreme round-trip */
    do {
        FD_ZERO(&readfds);
        openssl_fdset(s, &readfds);
    } while (select(s + 1, &readfds, NULL, NULL, &timeout) > 0
             && BIO_read(sbio, sbuf, BUFSIZZ) > 0);

R
Rich Salz 已提交
3157
    BIO_closesocket(SSL_get_fd(con));
3158 3159 3160
 end:
    if (con != NULL) {
        if (prexit != 0)
R
Rob Percival 已提交
3161
            print_stuff(bio_c_out, con, 1);
3162 3163
        SSL_free(con);
    }
3164
    SSL_SESSION_free(psksess);
3165
#if !defined(OPENSSL_NO_NEXTPROTONEG)
R
Rich Salz 已提交
3166
    OPENSSL_free(next_proto.data);
3167
#endif
R
Rich Salz 已提交
3168
    SSL_CTX_free(ctx);
3169
    set_keylog_file(NULL, NULL);
R
Rich Salz 已提交
3170
    X509_free(cert);
R
Rich Salz 已提交
3171
    sk_X509_CRL_pop_free(crls, X509_CRL_free);
R
Rich Salz 已提交
3172
    EVP_PKEY_free(key);
R
Rich Salz 已提交
3173
    sk_X509_pop_free(chain, X509_free);
R
Rich Salz 已提交
3174
    OPENSSL_free(pass);
D
Dr. Stephen Henson 已提交
3175 3176 3177
#ifndef OPENSSL_NO_SRP
    OPENSSL_free(srp_arg.srppassin);
#endif
D
Dr. Stephen Henson 已提交
3178
    OPENSSL_free(connectstr);
3179
    OPENSSL_free(bindstr);
3180 3181
    OPENSSL_free(host);
    OPENSSL_free(port);
R
Rich Salz 已提交
3182
    X509_VERIFY_PARAM_free(vpm);
3183
    ssl_excert_free(exc);
3184
    sk_OPENSSL_STRING_free(ssl_args);
V
Viktor Dukhovni 已提交
3185
    sk_OPENSSL_STRING_free(dane_tlsa_rrset);
R
Rich Salz 已提交
3186
    SSL_CONF_CTX_free(cctx);
R
Rich Salz 已提交
3187 3188 3189
    OPENSSL_clear_free(cbuf, BUFSIZZ);
    OPENSSL_clear_free(sbuf, BUFSIZZ);
    OPENSSL_clear_free(mbuf, BUFSIZZ);
3190 3191
    if (proxypass != NULL)
        OPENSSL_clear_free(proxypass, strlen(proxypass));
3192
    release_engine(e);
R
Rich Salz 已提交
3193 3194 3195 3196
    BIO_free(bio_c_out);
    bio_c_out = NULL;
    BIO_free(bio_c_msg);
    bio_c_msg = NULL;
K
KaoruToda 已提交
3197
    return ret;
3198
}
3199

R
Rob Percival 已提交
3200
static void print_stuff(BIO *bio, SSL *s, int full)
3201 3202 3203 3204
{
    X509 *peer = NULL;
    STACK_OF(X509) *sk;
    const SSL_CIPHER *c;
3205 3206
    int i, istls13 = (SSL_version(s) == TLS1_3_VERSION);
    long verify_result;
3207
#ifndef OPENSSL_NO_COMP
3208 3209 3210
    const COMP_METHOD *comp, *expansion;
#endif
    unsigned char *exportedkeymat;
3211
#ifndef OPENSSL_NO_CT
R
Rob Percival 已提交
3212
    const SSL_CTX *ctx = SSL_get_SSL_CTX(s);
3213
#endif
3214 3215 3216 3217 3218 3219

    if (full) {
        int got_a_chain = 0;

        sk = SSL_get_peer_cert_chain(s);
        if (sk != NULL) {
3220
            got_a_chain = 1;
3221 3222 3223

            BIO_printf(bio, "---\nCertificate chain\n");
            for (i = 0; i < sk_X509_num(sk); i++) {
3224 3225 3226 3227 3228 3229
                BIO_printf(bio, "%2d s:", i);
                X509_NAME_print_ex(bio, X509_get_subject_name(sk_X509_value(sk, i)), 0, get_nameopt());
                BIO_puts(bio, "\n");
                BIO_printf(bio, "   i:");
                X509_NAME_print_ex(bio, X509_get_issuer_name(sk_X509_value(sk, i)), 0, get_nameopt());
                BIO_puts(bio, "\n");
3230 3231 3232 3233 3234 3235 3236 3237 3238 3239 3240 3241 3242
                if (c_showcerts)
                    PEM_write_bio_X509(bio, sk_X509_value(sk, i));
            }
        }

        BIO_printf(bio, "---\n");
        peer = SSL_get_peer_certificate(s);
        if (peer != NULL) {
            BIO_printf(bio, "Server certificate\n");

            /* Redundant if we showed the whole chain */
            if (!(c_showcerts && got_a_chain))
                PEM_write_bio_X509(bio, peer);
3243
            dump_cert_text(bio, peer);
3244
        } else {
3245
            BIO_printf(bio, "no peer certificate available\n");
3246
        }
3247
        print_ca_names(bio, s);
3248 3249 3250 3251

        ssl_print_sigalgs(bio, s);
        ssl_print_tmp_key(bio, s);

3252
#ifndef OPENSSL_NO_CT
3253 3254 3255 3256 3257 3258 3259 3260 3261 3262 3263 3264 3265 3266 3267 3268 3269 3270 3271 3272 3273 3274 3275 3276 3277 3278 3279 3280 3281
        /*
         * When the SSL session is anonymous, or resumed via an abbreviated
         * handshake, no SCTs are provided as part of the handshake.  While in
         * a resumed session SCTs may be present in the session's certificate,
         * no callbacks are invoked to revalidate these, and in any case that
         * set of SCTs may be incomplete.  Thus it makes little sense to
         * attempt to display SCTs from a resumed session's certificate, and of
         * course none are associated with an anonymous peer.
         */
        if (peer != NULL && !SSL_session_reused(s) && SSL_ct_is_enabled(s)) {
            const STACK_OF(SCT) *scts = SSL_get0_peer_scts(s);
            int sct_count = scts != NULL ? sk_SCT_num(scts) : 0;

            BIO_printf(bio, "---\nSCTs present (%i)\n", sct_count);
            if (sct_count > 0) {
                const CTLOG_STORE *log_store = SSL_CTX_get0_ctlog_store(ctx);

                BIO_printf(bio, "---\n");
                for (i = 0; i < sct_count; ++i) {
                    SCT *sct = sk_SCT_value(scts, i);

                    BIO_printf(bio, "SCT validation status: %s\n",
                               SCT_validation_status_string(sct));
                    SCT_print(sct, bio, 0, log_store);
                    if (i < sct_count - 1)
                        BIO_printf(bio, "\n---\n");
                }
                BIO_printf(bio, "\n");
            }
3282
        }
3283 3284
#endif

3285
        BIO_printf(bio,
3286 3287
                   "---\nSSL handshake has read %ju bytes "
                   "and written %ju bytes\n",
R
Rich Salz 已提交
3288 3289
                   BIO_number_read(SSL_get_rbio(s)),
                   BIO_number_written(SSL_get_wbio(s)));
3290
    }
3291
    print_verify_detail(s, bio);
3292
    BIO_printf(bio, (SSL_session_reused(s) ? "---\nReused, " : "---\nNew, "));
3293 3294 3295 3296 3297
    c = SSL_get_current_cipher(s);
    BIO_printf(bio, "%s, Cipher is %s\n",
               SSL_CIPHER_get_version(c), SSL_CIPHER_get_name(c));
    if (peer != NULL) {
        EVP_PKEY *pktmp;
3298

D
Dr. Stephen Henson 已提交
3299
        pktmp = X509_get0_pubkey(peer);
3300 3301 3302 3303 3304
        BIO_printf(bio, "Server public key is %d bit\n",
                   EVP_PKEY_bits(pktmp));
    }
    BIO_printf(bio, "Secure Renegotiation IS%s supported\n",
               SSL_get_secure_renegotiation_support(s) ? "" : " NOT");
3305
#ifndef OPENSSL_NO_COMP
3306 3307 3308 3309 3310 3311 3312
    comp = SSL_get_current_compression(s);
    expansion = SSL_get_current_expansion(s);
    BIO_printf(bio, "Compression: %s\n",
               comp ? SSL_COMP_get_name(comp) : "NONE");
    BIO_printf(bio, "Expansion: %s\n",
               expansion ? SSL_COMP_get_name(expansion) : "NONE");
#endif
3313 3314 3315 3316
#ifndef OPENSSL_NO_KTLS
    if (BIO_get_ktls_send(SSL_get_wbio(s)))
        BIO_printf(bio_err, "Using Kernel TLS for sending\n");
#endif
3317

3318
    if (OSSL_TRACE_ENABLED(TLS)) {
3319 3320
        /* Print out local port of connection: useful for debugging */
        int sock;
3321 3322
        union BIO_sock_info_u info;

3323
        sock = SSL_get_fd(s);
3324 3325 3326
        if ((info.addr = BIO_ADDR_new()) != NULL
            && BIO_sock_info(sock, BIO_SOCK_INFO_ADDRESS, &info)) {
            BIO_printf(bio_c_out, "LOCAL PORT is %u\n",
J
Jon Loeliger 已提交
3327
                       ntohs(BIO_ADDR_rawport(info.addr)));
3328 3329
        }
        BIO_ADDR_free(info.addr);
3330
    }
3331

3332
#if !defined(OPENSSL_NO_NEXTPROTONEG)
3333 3334 3335 3336 3337 3338 3339 3340
    if (next_proto.status != -1) {
        const unsigned char *proto;
        unsigned int proto_len;
        SSL_get0_next_proto_negotiated(s, &proto, &proto_len);
        BIO_printf(bio, "Next protocol: (%d) ", next_proto.status);
        BIO_write(bio, proto, proto_len);
        BIO_write(bio, "\n", 1);
    }
3341
#endif
3342 3343 3344 3345 3346 3347 3348 3349 3350 3351 3352
    {
        const unsigned char *proto;
        unsigned int proto_len;
        SSL_get0_alpn_selected(s, &proto, &proto_len);
        if (proto_len > 0) {
            BIO_printf(bio, "ALPN protocol: ");
            BIO_write(bio, proto, proto_len);
            BIO_write(bio, "\n", 1);
        } else
            BIO_printf(bio, "No ALPN negotiated\n");
    }
3353

P
Piotr Sikora 已提交
3354
#ifndef OPENSSL_NO_SRTP
3355 3356 3357 3358 3359 3360 3361 3362 3363 3364
    {
        SRTP_PROTECTION_PROFILE *srtp_profile =
            SSL_get_selected_srtp_profile(s);

        if (srtp_profile)
            BIO_printf(bio, "SRTP Extension negotiated, profile=%s\n",
                       srtp_profile->name);
    }
#endif

3365
    if (istls13) {
3366 3367 3368 3369 3370 3371 3372 3373 3374 3375 3376 3377 3378 3379
        switch (SSL_get_early_data_status(s)) {
        case SSL_EARLY_DATA_NOT_SENT:
            BIO_printf(bio, "Early data was not sent\n");
            break;

        case SSL_EARLY_DATA_REJECTED:
            BIO_printf(bio, "Early data was rejected\n");
            break;

        case SSL_EARLY_DATA_ACCEPTED:
            BIO_printf(bio, "Early data was accepted\n");
            break;

        }
3380 3381 3382 3383 3384 3385 3386 3387 3388 3389 3390 3391

        /*
         * We also print the verify results when we dump session information,
         * but in TLSv1.3 we may not get that right away (or at all) depending
         * on when we get a NewSessionTicket. Therefore we print it now as well.
         */
        verify_result = SSL_get_verify_result(s);
        BIO_printf(bio, "Verify return code: %ld (%s)\n", verify_result,
                   X509_verify_cert_error_string(verify_result));
    } else {
        /* In TLSv1.3 we do this on arrival of a NewSessionTicket */
        SSL_SESSION_print(bio, SSL_get_session(s));
3392 3393
    }

F
FdaSilvaYY 已提交
3394
    if (SSL_get_session(s) != NULL && keymatexportlabel != NULL) {
3395 3396 3397
        BIO_printf(bio, "Keying material exporter:\n");
        BIO_printf(bio, "    Label: '%s'\n", keymatexportlabel);
        BIO_printf(bio, "    Length: %i bytes\n", keymatexportlen);
R
Rich Salz 已提交
3398 3399 3400 3401 3402 3403 3404 3405 3406 3407 3408 3409
        exportedkeymat = app_malloc(keymatexportlen, "export key");
        if (!SSL_export_keying_material(s, exportedkeymat,
                                        keymatexportlen,
                                        keymatexportlabel,
                                        strlen(keymatexportlabel),
                                        NULL, 0, 0)) {
            BIO_printf(bio, "    Error\n");
        } else {
            BIO_printf(bio, "    Keying material: ");
            for (i = 0; i < keymatexportlen; i++)
                BIO_printf(bio, "%02X", exportedkeymat[i]);
            BIO_printf(bio, "\n");
3410
        }
R
Rich Salz 已提交
3411
        OPENSSL_free(exportedkeymat);
3412 3413
    }
    BIO_printf(bio, "---\n");
R
Rich Salz 已提交
3414
    X509_free(peer);
3415 3416 3417
    /* flush, or debugging output gets mixed with http response */
    (void)BIO_flush(bio);
}
3418

M
Matt Caswell 已提交
3419
# ifndef OPENSSL_NO_OCSP
3420
static int ocsp_resp_cb(SSL *s, void *arg)
3421 3422 3423 3424 3425 3426
{
    const unsigned char *p;
    int len;
    OCSP_RESPONSE *rsp;
    len = SSL_get_tlsext_status_ocsp_resp(s, &p);
    BIO_puts(arg, "OCSP response: ");
3427
    if (p == NULL) {
3428 3429 3430 3431
        BIO_puts(arg, "no response sent\n");
        return 1;
    }
    rsp = d2i_OCSP_RESPONSE(NULL, &p, len);
3432
    if (rsp == NULL) {
3433 3434 3435 3436 3437 3438 3439 3440 3441 3442
        BIO_puts(arg, "response parse error\n");
        BIO_dump_indent(arg, (char *)p, len, 4);
        return 0;
    }
    BIO_puts(arg, "\n======================================\n");
    OCSP_RESPONSE_print(arg, rsp, 0);
    BIO_puts(arg, "======================================\n");
    OCSP_RESPONSE_free(rsp);
    return 1;
}
M
Matt Caswell 已提交
3443
# endif
M
Matt Caswell 已提交
3444

3445 3446 3447 3448 3449 3450 3451 3452 3453 3454 3455 3456 3457 3458 3459 3460 3461 3462 3463 3464 3465 3466 3467 3468 3469 3470 3471 3472 3473 3474 3475 3476 3477 3478 3479 3480 3481 3482 3483 3484 3485 3486 3487 3488
static int ldap_ExtendedResponse_parse(const char *buf, long rem)
{
    const unsigned char *cur, *end;
    long len;
    int tag, xclass, inf, ret = -1;

    cur = (const unsigned char *)buf;
    end = cur + rem;

    /*
     * From RFC 4511:
     *
     *    LDAPMessage ::= SEQUENCE {
     *         messageID       MessageID,
     *         protocolOp      CHOICE {
     *              ...
     *              extendedResp          ExtendedResponse,
     *              ... },
     *         controls       [0] Controls OPTIONAL }
     *
     *    ExtendedResponse ::= [APPLICATION 24] SEQUENCE {
     *         COMPONENTS OF LDAPResult,
     *         responseName     [10] LDAPOID OPTIONAL,
     *         responseValue    [11] OCTET STRING OPTIONAL }
     *
     *    LDAPResult ::= SEQUENCE {
     *         resultCode         ENUMERATED {
     *              success                      (0),
     *              ...
     *              other                        (80),
     *              ...  },
     *         matchedDN          LDAPDN,
     *         diagnosticMessage  LDAPString,
     *         referral           [3] Referral OPTIONAL }
     */

    /* pull SEQUENCE */
    inf = ASN1_get_object(&cur, &len, &tag, &xclass, rem);
    if (inf != V_ASN1_CONSTRUCTED || tag != V_ASN1_SEQUENCE ||
        (rem = end - cur, len > rem)) {
        BIO_printf(bio_err, "Unexpected LDAP response\n");
        goto end;
    }

3489 3490
    rem = len;  /* ensure that we don't overstep the SEQUENCE */

3491 3492 3493 3494 3495 3496 3497 3498 3499 3500 3501 3502 3503 3504 3505 3506 3507 3508 3509 3510 3511 3512 3513 3514 3515 3516 3517 3518 3519 3520 3521 3522 3523 3524 3525 3526 3527 3528
    /* pull MessageID */
    inf = ASN1_get_object(&cur, &len, &tag, &xclass, rem);
    if (inf != V_ASN1_UNIVERSAL || tag != V_ASN1_INTEGER ||
        (rem = end - cur, len > rem)) {
        BIO_printf(bio_err, "No MessageID\n");
        goto end;
    }

    cur += len; /* shall we check for MessageId match or just skip? */

    /* pull [APPLICATION 24] */
    rem = end - cur;
    inf = ASN1_get_object(&cur, &len, &tag, &xclass, rem);
    if (inf != V_ASN1_CONSTRUCTED || xclass != V_ASN1_APPLICATION ||
        tag != 24) {
        BIO_printf(bio_err, "Not ExtendedResponse\n");
        goto end;
    }

    /* pull resultCode */
    rem = end - cur;
    inf = ASN1_get_object(&cur, &len, &tag, &xclass, rem);
    if (inf != V_ASN1_UNIVERSAL || tag != V_ASN1_ENUMERATED || len == 0 ||
        (rem = end - cur, len > rem)) {
        BIO_printf(bio_err, "Not LDAPResult\n");
        goto end;
    }

    /* len should always be one, but just in case... */
    for (ret = 0, inf = 0; inf < len; inf++) {
        ret <<= 8;
        ret |= cur[inf];
    }
    /* There is more data, but we don't care... */
 end:
    return ret;
}

3529 3530 3531 3532 3533 3534 3535 3536 3537 3538 3539 3540 3541 3542 3543 3544 3545 3546 3547
/*
 * BASE64 encoder: used only for encoding basic proxy authentication credentials
 */
static char *base64encode (const void *buf, size_t len)
{
    int i;
    size_t outl;
    char  *out;

    /* Calculate size of encoded data */
    outl = (len / 3);
    if (len % 3 > 0)
        outl++;
    outl <<= 2;
    out = app_malloc(outl + 1, "base64 encode buffer");

    i = EVP_EncodeBlock((unsigned char *)out, buf, len);
    assert(i <= (int)outl);
    if (i < 0)
3548
        *out = '\0';
3549 3550 3551
    return out;
}

3552 3553 3554 3555 3556 3557 3558 3559 3560 3561 3562 3563 3564 3565 3566 3567 3568 3569 3570 3571 3572 3573 3574 3575 3576 3577 3578 3579 3580 3581 3582 3583 3584 3585 3586 3587 3588 3589 3590 3591 3592 3593 3594 3595 3596 3597 3598 3599 3600 3601 3602 3603 3604 3605 3606 3607 3608 3609 3610 3611 3612 3613 3614 3615 3616
/*
 * Host dNS Name verifier: used for checking that the hostname is in dNS format 
 * before setting it as SNI
 */
static int is_dNS_name(const char *host)
{
    const size_t MAX_LABEL_LENGTH = 63;
    size_t i;
    int isdnsname = 0;
    size_t length = strlen(host);
    size_t label_length = 0;
    int all_numeric = 1;

    /*
     * Deviation from strict DNS name syntax, also check names with '_'
     * Check DNS name syntax, any '-' or '.' must be internal,
     * and on either side of each '.' we can't have a '-' or '.'.
     *
     * If the name has just one label, we don't consider it a DNS name.
     */
    for (i = 0; i < length && label_length < MAX_LABEL_LENGTH; ++i) {
        char c = host[i];

        if ((c >= 'a' && c <= 'z')
            || (c >= 'A' && c <= 'Z')
            || c == '_') {
            label_length += 1;
            all_numeric = 0;
            continue;
        }

        if (c >= '0' && c <= '9') {
            label_length += 1;
            continue;
        }

        /* Dot and hyphen cannot be first or last. */
        if (i > 0 && i < length - 1) {
            if (c == '-') {
                label_length += 1;
                continue;
            }
            /*
             * Next to a dot the preceding and following characters must not be
             * another dot or a hyphen.  Otherwise, record that the name is
             * plausible, since it has two or more labels.
             */
            if (c == '.'
                && host[i + 1] != '.'
                && host[i - 1] != '-'
                && host[i + 1] != '-') {
                label_length = 0;
                isdnsname = 1;
                continue;
            }
        }
        isdnsname = 0;
        break;
    }

    /* dNS name must not be all numeric and labels must be shorter than 64 characters. */
    isdnsname &= !all_numeric && !(label_length == MAX_LABEL_LENGTH);

    return isdnsname;
}
F
FdaSilvaYY 已提交
3617
#endif                          /* OPENSSL_NO_SOCK */