1 /***************************************************************************
2 * _ _ ____ _
3 * Project ___| | | | _ \| |
4 * / __| | | | |_) | |
5 * | (__| |_| | _ <| |___
6 * \___|\___/|_| \_\_____|
7 *
8 * Copyright (C) Daniel Stenberg, <daniel@haxx.se>, et al.
9 *
10 * This software is licensed as described in the file COPYING, which
11 * you should have received as part of this distribution. The terms
12 * are also available at https://curl.se/docs/copyright.html.
13 *
14 * You may opt to use, copy, modify, merge, publish, distribute and/or sell
15 * copies of the Software, and permit persons to whom the Software is
16 * furnished to do so, under the terms of the COPYING file.
17 *
18 * This software is distributed on an "AS IS" basis, WITHOUT WARRANTY OF ANY
19 * KIND, either express or implied.
20 *
21 * SPDX-License-Identifier: curl
22 *
23 ***************************************************************************/
24
25 /* This file is for implementing all "generic" SSL functions that all libcurl
26 internals should use. It is then responsible for calling the proper
27 "backend" function.
28
29 SSL-functions in libcurl should call functions in this source file, and not
30 to any specific SSL-layer.
31
32 Curl_ssl_ - prefix for generic ones
33
34 Note that this source code uses the functions of the configured SSL
35 backend via the global Curl_ssl instance.
36
37 "SSL/TLS Strong Encryption: An Introduction"
38 https://httpd.apache.org/docs/2.0/ssl/ssl_intro.html
39 */
40
41 #include "curl_setup.h"
42
43 #ifdef HAVE_SYS_TYPES_H
44 #include <sys/types.h>
45 #endif
46 #ifdef HAVE_SYS_STAT_H
47 #include <sys/stat.h>
48 #endif
49 #ifdef HAVE_FCNTL_H
50 #include <fcntl.h>
51 #endif
52
53 #include "urldata.h"
54 #include "cfilters.h"
55
56 #include "vtls.h" /* generic SSL protos etc */
57 #include "vtls_int.h"
58 #include "slist.h"
59 #include "sendf.h"
60 #include "strcase.h"
61 #include "url.h"
62 #include "progress.h"
63 #include "share.h"
64 #include "multiif.h"
65 #include "timeval.h"
66 #include "curl_md5.h"
67 #include "warnless.h"
68 #include "curl_base64.h"
69 #include "curl_printf.h"
70 #include "inet_pton.h"
71 #include "strdup.h"
72
73 /* The last #include files should be: */
74 #include "curl_memory.h"
75 #include "memdebug.h"
76
77
78 /* convenience macro to check if this handle is using a shared SSL session */
79 #define SSLSESSION_SHARED(data) (data->share && \
80 (data->share->specifier & \
81 (1<<CURL_LOCK_DATA_SSL_SESSION)))
82
83 #define CLONE_STRING(var) \
84 do { \
85 if(source->var) { \
86 dest->var = strdup(source->var); \
87 if(!dest->var) \
88 return FALSE; \
89 } \
90 else \
91 dest->var = NULL; \
92 } while(0)
93
94 #define CLONE_BLOB(var) \
95 do { \
96 if(blobdup(&dest->var, source->var)) \
97 return FALSE; \
98 } while(0)
99
blobdup(struct curl_blob ** dest,struct curl_blob * src)100 static CURLcode blobdup(struct curl_blob **dest,
101 struct curl_blob *src)
102 {
103 DEBUGASSERT(dest);
104 DEBUGASSERT(!*dest);
105 if(src) {
106 /* only if there's data to dupe! */
107 struct curl_blob *d;
108 d = malloc(sizeof(struct curl_blob) + src->len);
109 if(!d)
110 return CURLE_OUT_OF_MEMORY;
111 d->len = src->len;
112 /* Always duplicate because the connection may survive longer than the
113 handle that passed in the blob. */
114 d->flags = CURL_BLOB_COPY;
115 d->data = (void *)((char *)d + sizeof(struct curl_blob));
116 memcpy(d->data, src->data, src->len);
117 *dest = d;
118 }
119 return CURLE_OK;
120 }
121
122 /* returns TRUE if the blobs are identical */
blobcmp(struct curl_blob * first,struct curl_blob * second)123 static bool blobcmp(struct curl_blob *first, struct curl_blob *second)
124 {
125 if(!first && !second) /* both are NULL */
126 return TRUE;
127 if(!first || !second) /* one is NULL */
128 return FALSE;
129 if(first->len != second->len) /* different sizes */
130 return FALSE;
131 return !memcmp(first->data, second->data, first->len); /* same data */
132 }
133
134 #ifdef USE_SSL
135 static const struct alpn_spec ALPN_SPEC_H11 = {
136 { ALPN_HTTP_1_1 }, 1
137 };
138 #ifdef USE_HTTP2
139 static const struct alpn_spec ALPN_SPEC_H2_H11 = {
140 { ALPN_H2, ALPN_HTTP_1_1 }, 2
141 };
142 #endif
143
alpn_get_spec(int httpwant,bool use_alpn)144 static const struct alpn_spec *alpn_get_spec(int httpwant, bool use_alpn)
145 {
146 if(!use_alpn)
147 return NULL;
148 #ifdef USE_HTTP2
149 if(httpwant >= CURL_HTTP_VERSION_2)
150 return &ALPN_SPEC_H2_H11;
151 #else
152 (void)httpwant;
153 #endif
154 /* Use the ALPN protocol "http/1.1" for HTTP/1.x.
155 Avoid "http/1.0" because some servers don't support it. */
156 return &ALPN_SPEC_H11;
157 }
158 #endif /* USE_SSL */
159
160
Curl_ssl_easy_config_init(struct Curl_easy * data)161 void Curl_ssl_easy_config_init(struct Curl_easy *data)
162 {
163 /*
164 * libcurl 7.10 introduced SSL verification *by default*! This needs to be
165 * switched off unless wanted.
166 */
167 data->set.ssl.primary.verifypeer = TRUE;
168 data->set.ssl.primary.verifyhost = TRUE;
169 data->set.ssl.primary.sessionid = TRUE; /* session ID caching by default */
170 #ifndef CURL_DISABLE_PROXY
171 data->set.proxy_ssl = data->set.ssl;
172 #endif
173 }
174
175 static bool
match_ssl_primary_config(struct Curl_easy * data,struct ssl_primary_config * c1,struct ssl_primary_config * c2)176 match_ssl_primary_config(struct Curl_easy *data,
177 struct ssl_primary_config *c1,
178 struct ssl_primary_config *c2)
179 {
180 (void)data;
181 if((c1->version == c2->version) &&
182 (c1->version_max == c2->version_max) &&
183 (c1->ssl_options == c2->ssl_options) &&
184 (c1->verifypeer == c2->verifypeer) &&
185 (c1->verifyhost == c2->verifyhost) &&
186 (c1->verifystatus == c2->verifystatus) &&
187 blobcmp(c1->cert_blob, c2->cert_blob) &&
188 blobcmp(c1->ca_info_blob, c2->ca_info_blob) &&
189 blobcmp(c1->issuercert_blob, c2->issuercert_blob) &&
190 Curl_safecmp(c1->CApath, c2->CApath) &&
191 Curl_safecmp(c1->CAfile, c2->CAfile) &&
192 Curl_safecmp(c1->issuercert, c2->issuercert) &&
193 Curl_safecmp(c1->clientcert, c2->clientcert) &&
194 #ifdef USE_TLS_SRP
195 !Curl_timestrcmp(c1->username, c2->username) &&
196 !Curl_timestrcmp(c1->password, c2->password) &&
197 #endif
198 strcasecompare(c1->cipher_list, c2->cipher_list) &&
199 strcasecompare(c1->cipher_list13, c2->cipher_list13) &&
200 strcasecompare(c1->curves, c2->curves) &&
201 strcasecompare(c1->CRLfile, c2->CRLfile) &&
202 strcasecompare(c1->pinned_key, c2->pinned_key))
203 return TRUE;
204
205 return FALSE;
206 }
207
Curl_ssl_conn_config_match(struct Curl_easy * data,struct connectdata * candidate,bool proxy)208 bool Curl_ssl_conn_config_match(struct Curl_easy *data,
209 struct connectdata *candidate,
210 bool proxy)
211 {
212 #ifndef CURL_DISABLE_PROXY
213 if(proxy)
214 return match_ssl_primary_config(data, &data->set.proxy_ssl.primary,
215 &candidate->proxy_ssl_config);
216 #else
217 (void)proxy;
218 #endif
219 return match_ssl_primary_config(data, &data->set.ssl.primary,
220 &candidate->ssl_config);
221 }
222
clone_ssl_primary_config(struct ssl_primary_config * source,struct ssl_primary_config * dest)223 static bool clone_ssl_primary_config(struct ssl_primary_config *source,
224 struct ssl_primary_config *dest)
225 {
226 dest->version = source->version;
227 dest->version_max = source->version_max;
228 dest->verifypeer = source->verifypeer;
229 dest->verifyhost = source->verifyhost;
230 dest->verifystatus = source->verifystatus;
231 dest->sessionid = source->sessionid;
232 dest->ssl_options = source->ssl_options;
233
234 CLONE_BLOB(cert_blob);
235 CLONE_BLOB(ca_info_blob);
236 CLONE_BLOB(issuercert_blob);
237 CLONE_STRING(CApath);
238 CLONE_STRING(CAfile);
239 CLONE_STRING(issuercert);
240 CLONE_STRING(clientcert);
241 CLONE_STRING(cipher_list);
242 CLONE_STRING(cipher_list13);
243 CLONE_STRING(pinned_key);
244 CLONE_STRING(curves);
245 CLONE_STRING(CRLfile);
246 #ifdef USE_TLS_SRP
247 CLONE_STRING(username);
248 CLONE_STRING(password);
249 #endif
250
251 return TRUE;
252 }
253
Curl_free_primary_ssl_config(struct ssl_primary_config * sslc)254 static void Curl_free_primary_ssl_config(struct ssl_primary_config *sslc)
255 {
256 Curl_safefree(sslc->CApath);
257 Curl_safefree(sslc->CAfile);
258 Curl_safefree(sslc->issuercert);
259 Curl_safefree(sslc->clientcert);
260 Curl_safefree(sslc->cipher_list);
261 Curl_safefree(sslc->cipher_list13);
262 Curl_safefree(sslc->pinned_key);
263 Curl_safefree(sslc->cert_blob);
264 Curl_safefree(sslc->ca_info_blob);
265 Curl_safefree(sslc->issuercert_blob);
266 Curl_safefree(sslc->curves);
267 Curl_safefree(sslc->CRLfile);
268 #ifdef USE_TLS_SRP
269 Curl_safefree(sslc->username);
270 Curl_safefree(sslc->password);
271 #endif
272 }
273
Curl_ssl_easy_config_complete(struct Curl_easy * data)274 CURLcode Curl_ssl_easy_config_complete(struct Curl_easy *data)
275 {
276 data->set.ssl.primary.CApath = data->set.str[STRING_SSL_CAPATH];
277 data->set.ssl.primary.CAfile = data->set.str[STRING_SSL_CAFILE];
278 data->set.ssl.primary.CRLfile = data->set.str[STRING_SSL_CRLFILE];
279 data->set.ssl.primary.issuercert = data->set.str[STRING_SSL_ISSUERCERT];
280 data->set.ssl.primary.issuercert_blob = data->set.blobs[BLOB_SSL_ISSUERCERT];
281 data->set.ssl.primary.cipher_list =
282 data->set.str[STRING_SSL_CIPHER_LIST];
283 data->set.ssl.primary.cipher_list13 =
284 data->set.str[STRING_SSL_CIPHER13_LIST];
285 data->set.ssl.primary.pinned_key =
286 data->set.str[STRING_SSL_PINNEDPUBLICKEY];
287 data->set.ssl.primary.cert_blob = data->set.blobs[BLOB_CERT];
288 data->set.ssl.primary.ca_info_blob = data->set.blobs[BLOB_CAINFO];
289 data->set.ssl.primary.curves = data->set.str[STRING_SSL_EC_CURVES];
290 #ifdef USE_TLS_SRP
291 data->set.ssl.primary.username = data->set.str[STRING_TLSAUTH_USERNAME];
292 data->set.ssl.primary.password = data->set.str[STRING_TLSAUTH_PASSWORD];
293 #endif
294 data->set.ssl.cert_type = data->set.str[STRING_CERT_TYPE];
295 data->set.ssl.key = data->set.str[STRING_KEY];
296 data->set.ssl.key_type = data->set.str[STRING_KEY_TYPE];
297 data->set.ssl.key_passwd = data->set.str[STRING_KEY_PASSWD];
298 data->set.ssl.primary.clientcert = data->set.str[STRING_CERT];
299 data->set.ssl.key_blob = data->set.blobs[BLOB_KEY];
300
301 #ifndef CURL_DISABLE_PROXY
302 data->set.proxy_ssl.primary.CApath = data->set.str[STRING_SSL_CAPATH_PROXY];
303 data->set.proxy_ssl.primary.CAfile = data->set.str[STRING_SSL_CAFILE_PROXY];
304 data->set.proxy_ssl.primary.cipher_list =
305 data->set.str[STRING_SSL_CIPHER_LIST_PROXY];
306 data->set.proxy_ssl.primary.cipher_list13 =
307 data->set.str[STRING_SSL_CIPHER13_LIST_PROXY];
308 data->set.proxy_ssl.primary.pinned_key =
309 data->set.str[STRING_SSL_PINNEDPUBLICKEY_PROXY];
310 data->set.proxy_ssl.primary.cert_blob = data->set.blobs[BLOB_CERT_PROXY];
311 data->set.proxy_ssl.primary.ca_info_blob =
312 data->set.blobs[BLOB_CAINFO_PROXY];
313 data->set.proxy_ssl.primary.issuercert =
314 data->set.str[STRING_SSL_ISSUERCERT_PROXY];
315 data->set.proxy_ssl.primary.issuercert_blob =
316 data->set.blobs[BLOB_SSL_ISSUERCERT_PROXY];
317 data->set.proxy_ssl.primary.CRLfile =
318 data->set.str[STRING_SSL_CRLFILE_PROXY];
319 data->set.proxy_ssl.cert_type = data->set.str[STRING_CERT_TYPE_PROXY];
320 data->set.proxy_ssl.key = data->set.str[STRING_KEY_PROXY];
321 data->set.proxy_ssl.key_type = data->set.str[STRING_KEY_TYPE_PROXY];
322 data->set.proxy_ssl.key_passwd = data->set.str[STRING_KEY_PASSWD_PROXY];
323 data->set.proxy_ssl.primary.clientcert = data->set.str[STRING_CERT_PROXY];
324 data->set.proxy_ssl.key_blob = data->set.blobs[BLOB_KEY_PROXY];
325 #ifdef USE_TLS_SRP
326 data->set.proxy_ssl.primary.username =
327 data->set.str[STRING_TLSAUTH_USERNAME_PROXY];
328 data->set.proxy_ssl.primary.password =
329 data->set.str[STRING_TLSAUTH_PASSWORD_PROXY];
330 #endif
331 #endif /* CURL_DISABLE_PROXY */
332
333 return CURLE_OK;
334 }
335
Curl_ssl_conn_config_init(struct Curl_easy * data,struct connectdata * conn)336 CURLcode Curl_ssl_conn_config_init(struct Curl_easy *data,
337 struct connectdata *conn)
338 {
339 /* Clone "primary" SSL configurations from the esay handle to
340 * the connection. They are used for connection cache matching and
341 * probably outlive the easy handle */
342 if(!clone_ssl_primary_config(&data->set.ssl.primary, &conn->ssl_config))
343 return CURLE_OUT_OF_MEMORY;
344 #ifndef CURL_DISABLE_PROXY
345 if(!clone_ssl_primary_config(&data->set.proxy_ssl.primary,
346 &conn->proxy_ssl_config))
347 return CURLE_OUT_OF_MEMORY;
348 #endif
349 return CURLE_OK;
350 }
351
Curl_ssl_conn_config_cleanup(struct connectdata * conn)352 void Curl_ssl_conn_config_cleanup(struct connectdata *conn)
353 {
354 Curl_free_primary_ssl_config(&conn->ssl_config);
355 #ifndef CURL_DISABLE_PROXY
356 Curl_free_primary_ssl_config(&conn->proxy_ssl_config);
357 #endif
358 }
359
Curl_ssl_conn_config_update(struct Curl_easy * data,bool for_proxy)360 void Curl_ssl_conn_config_update(struct Curl_easy *data, bool for_proxy)
361 {
362 /* May be called on an easy that has no connection yet */
363 if(data->conn) {
364 struct ssl_primary_config *src, *dest;
365 #ifndef CURL_DISABLE_PROXY
366 src = for_proxy? &data->set.proxy_ssl.primary : &data->set.ssl.primary;
367 dest = for_proxy? &data->conn->proxy_ssl_config : &data->conn->ssl_config;
368 #else
369 (void)for_proxy;
370 src = &data->set.ssl.primary;
371 dest = &data->conn->ssl_config;
372 #endif
373 dest->verifyhost = src->verifyhost;
374 dest->verifypeer = src->verifypeer;
375 dest->verifystatus = src->verifystatus;
376 }
377 }
378
379 #ifdef USE_SSL
380 static int multissl_setup(const struct Curl_ssl *backend);
381 #endif
382
Curl_ssl_backend(void)383 curl_sslbackend Curl_ssl_backend(void)
384 {
385 #ifdef USE_SSL
386 multissl_setup(NULL);
387 return Curl_ssl->info.id;
388 #else
389 return CURLSSLBACKEND_NONE;
390 #endif
391 }
392
393 #ifdef USE_SSL
394
395 /* "global" init done? */
396 static bool init_ssl = FALSE;
397
398 /**
399 * Global SSL init
400 *
401 * @retval 0 error initializing SSL
402 * @retval 1 SSL initialized successfully
403 */
Curl_ssl_init(void)404 int Curl_ssl_init(void)
405 {
406 /* make sure this is only done once */
407 if(init_ssl)
408 return 1;
409 init_ssl = TRUE; /* never again */
410
411 return Curl_ssl->init();
412 }
413
414 #if defined(CURL_WITH_MULTI_SSL)
415 static const struct Curl_ssl Curl_ssl_multi;
416 #endif
417
418 /* Global cleanup */
Curl_ssl_cleanup(void)419 void Curl_ssl_cleanup(void)
420 {
421 if(init_ssl) {
422 /* only cleanup if we did a previous init */
423 Curl_ssl->cleanup();
424 #if defined(CURL_WITH_MULTI_SSL)
425 Curl_ssl = &Curl_ssl_multi;
426 #endif
427 init_ssl = FALSE;
428 }
429 }
430
ssl_prefs_check(struct Curl_easy * data)431 static bool ssl_prefs_check(struct Curl_easy *data)
432 {
433 /* check for CURLOPT_SSLVERSION invalid parameter value */
434 const unsigned char sslver = data->set.ssl.primary.version;
435 if(sslver >= CURL_SSLVERSION_LAST) {
436 failf(data, "Unrecognized parameter value passed via CURLOPT_SSLVERSION");
437 return FALSE;
438 }
439
440 switch(data->set.ssl.primary.version_max) {
441 case CURL_SSLVERSION_MAX_NONE:
442 case CURL_SSLVERSION_MAX_DEFAULT:
443 break;
444
445 default:
446 if((data->set.ssl.primary.version_max >> 16) < sslver) {
447 failf(data, "CURL_SSLVERSION_MAX incompatible with CURL_SSLVERSION");
448 return FALSE;
449 }
450 }
451
452 return TRUE;
453 }
454
cf_ctx_new(struct Curl_easy * data,const struct alpn_spec * alpn)455 static struct ssl_connect_data *cf_ctx_new(struct Curl_easy *data,
456 const struct alpn_spec *alpn)
457 {
458 struct ssl_connect_data *ctx;
459
460 (void)data;
461 ctx = calloc(1, sizeof(*ctx));
462 if(!ctx)
463 return NULL;
464
465 ctx->alpn = alpn;
466 ctx->backend = calloc(1, Curl_ssl->sizeof_ssl_backend_data);
467 if(!ctx->backend) {
468 free(ctx);
469 return NULL;
470 }
471 return ctx;
472 }
473
cf_ctx_free(struct ssl_connect_data * ctx)474 static void cf_ctx_free(struct ssl_connect_data *ctx)
475 {
476 if(ctx) {
477 free(ctx->backend);
478 free(ctx);
479 }
480 }
481
ssl_connect(struct Curl_cfilter * cf,struct Curl_easy * data)482 static CURLcode ssl_connect(struct Curl_cfilter *cf, struct Curl_easy *data)
483 {
484 struct ssl_connect_data *connssl = cf->ctx;
485 CURLcode result;
486
487 if(!ssl_prefs_check(data))
488 return CURLE_SSL_CONNECT_ERROR;
489
490 /* mark this is being ssl-enabled from here on. */
491 connssl->state = ssl_connection_negotiating;
492
493 result = Curl_ssl->connect_blocking(cf, data);
494
495 if(!result) {
496 DEBUGASSERT(connssl->state == ssl_connection_complete);
497 }
498
499 return result;
500 }
501
502 static CURLcode
ssl_connect_nonblocking(struct Curl_cfilter * cf,struct Curl_easy * data,bool * done)503 ssl_connect_nonblocking(struct Curl_cfilter *cf, struct Curl_easy *data,
504 bool *done)
505 {
506 if(!ssl_prefs_check(data))
507 return CURLE_SSL_CONNECT_ERROR;
508
509 /* mark this is being ssl requested from here on. */
510 return Curl_ssl->connect_nonblocking(cf, data, done);
511 }
512
513 /*
514 * Lock shared SSL session data
515 */
Curl_ssl_sessionid_lock(struct Curl_easy * data)516 void Curl_ssl_sessionid_lock(struct Curl_easy *data)
517 {
518 if(SSLSESSION_SHARED(data))
519 Curl_share_lock(data, CURL_LOCK_DATA_SSL_SESSION, CURL_LOCK_ACCESS_SINGLE);
520 }
521
522 /*
523 * Unlock shared SSL session data
524 */
Curl_ssl_sessionid_unlock(struct Curl_easy * data)525 void Curl_ssl_sessionid_unlock(struct Curl_easy *data)
526 {
527 if(SSLSESSION_SHARED(data))
528 Curl_share_unlock(data, CURL_LOCK_DATA_SSL_SESSION);
529 }
530
531 /*
532 * Check if there's a session ID for the given connection in the cache, and if
533 * there's one suitable, it is provided. Returns TRUE when no entry matched.
534 */
Curl_ssl_getsessionid(struct Curl_cfilter * cf,struct Curl_easy * data,const struct ssl_peer * peer,void ** ssl_sessionid,size_t * idsize)535 bool Curl_ssl_getsessionid(struct Curl_cfilter *cf,
536 struct Curl_easy *data,
537 const struct ssl_peer *peer,
538 void **ssl_sessionid,
539 size_t *idsize) /* set 0 if unknown */
540 {
541 struct ssl_primary_config *conn_config = Curl_ssl_cf_get_primary_config(cf);
542 struct ssl_config_data *ssl_config = Curl_ssl_cf_get_config(cf, data);
543 struct Curl_ssl_session *check;
544 size_t i;
545 long *general_age;
546 bool no_match = TRUE;
547
548 *ssl_sessionid = NULL;
549 if(!ssl_config)
550 return TRUE;
551
552 DEBUGASSERT(ssl_config->primary.sessionid);
553
554 if(!ssl_config->primary.sessionid || !data->state.session)
555 /* session ID reuse is disabled or the session cache has not been
556 setup */
557 return TRUE;
558
559 /* Lock if shared */
560 if(SSLSESSION_SHARED(data))
561 general_age = &data->share->sessionage;
562 else
563 general_age = &data->state.sessionage;
564
565 for(i = 0; i < data->set.general_ssl.max_ssl_sessions; i++) {
566 check = &data->state.session[i];
567 if(!check->sessionid)
568 /* not session ID means blank entry */
569 continue;
570 if(strcasecompare(peer->hostname, check->name) &&
571 ((!cf->conn->bits.conn_to_host && !check->conn_to_host) ||
572 (cf->conn->bits.conn_to_host && check->conn_to_host &&
573 strcasecompare(cf->conn->conn_to_host.name, check->conn_to_host))) &&
574 ((!cf->conn->bits.conn_to_port && check->conn_to_port == -1) ||
575 (cf->conn->bits.conn_to_port && check->conn_to_port != -1 &&
576 cf->conn->conn_to_port == check->conn_to_port)) &&
577 (peer->port == check->remote_port) &&
578 (peer->transport == check->transport) &&
579 strcasecompare(cf->conn->handler->scheme, check->scheme) &&
580 match_ssl_primary_config(data, conn_config, &check->ssl_config)) {
581 /* yes, we have a session ID! */
582 (*general_age)++; /* increase general age */
583 check->age = *general_age; /* set this as used in this age */
584 *ssl_sessionid = check->sessionid;
585 if(idsize)
586 *idsize = check->idsize;
587 no_match = FALSE;
588 break;
589 }
590 }
591
592 DEBUGF(infof(data, "%s Session ID in cache for %s %s://%s:%d",
593 no_match? "Didn't find": "Found",
594 Curl_ssl_cf_is_proxy(cf) ? "proxy" : "host",
595 cf->conn->handler->scheme, peer->hostname, peer->port));
596 return no_match;
597 }
598
599 /*
600 * Kill a single session ID entry in the cache.
601 */
Curl_ssl_kill_session(struct Curl_ssl_session * session)602 void Curl_ssl_kill_session(struct Curl_ssl_session *session)
603 {
604 if(session->sessionid) {
605 /* defensive check */
606
607 /* free the ID the SSL-layer specific way */
608 session->sessionid_free(session->sessionid, session->idsize);
609
610 session->sessionid = NULL;
611 session->sessionid_free = NULL;
612 session->age = 0; /* fresh */
613
614 Curl_free_primary_ssl_config(&session->ssl_config);
615
616 Curl_safefree(session->name);
617 Curl_safefree(session->conn_to_host);
618 }
619 }
620
621 /*
622 * Delete the given session ID from the cache.
623 */
Curl_ssl_delsessionid(struct Curl_easy * data,void * ssl_sessionid)624 void Curl_ssl_delsessionid(struct Curl_easy *data, void *ssl_sessionid)
625 {
626 size_t i;
627
628 for(i = 0; i < data->set.general_ssl.max_ssl_sessions; i++) {
629 struct Curl_ssl_session *check = &data->state.session[i];
630
631 if(check->sessionid == ssl_sessionid) {
632 Curl_ssl_kill_session(check);
633 break;
634 }
635 }
636 }
637
638 /*
639 * Store session id in the session cache. The ID passed on to this function
640 * must already have been extracted and allocated the proper way for the SSL
641 * layer. Curl_XXXX_session_free() will be called to free/kill the session ID
642 * later on.
643 */
Curl_ssl_addsessionid(struct Curl_cfilter * cf,struct Curl_easy * data,const struct ssl_peer * peer,void * ssl_sessionid,size_t idsize,Curl_ssl_sessionid_dtor * sessionid_free_cb)644 CURLcode Curl_ssl_addsessionid(struct Curl_cfilter *cf,
645 struct Curl_easy *data,
646 const struct ssl_peer *peer,
647 void *ssl_sessionid,
648 size_t idsize,
649 Curl_ssl_sessionid_dtor *sessionid_free_cb)
650 {
651 struct ssl_config_data *ssl_config = Curl_ssl_cf_get_config(cf, data);
652 struct ssl_primary_config *conn_config = Curl_ssl_cf_get_primary_config(cf);
653 size_t i;
654 struct Curl_ssl_session *store;
655 long oldest_age;
656 char *clone_host = NULL;
657 char *clone_conn_to_host = NULL;
658 int conn_to_port;
659 long *general_age;
660 CURLcode result = CURLE_OUT_OF_MEMORY;
661
662 DEBUGASSERT(ssl_sessionid);
663 DEBUGASSERT(sessionid_free_cb);
664
665 if(!data->state.session) {
666 sessionid_free_cb(ssl_sessionid, idsize);
667 return CURLE_OK;
668 }
669
670 store = &data->state.session[0];
671 oldest_age = data->state.session[0].age; /* zero if unused */
672 DEBUGASSERT(ssl_config->primary.sessionid);
673 (void)ssl_config;
674
675 clone_host = strdup(peer->hostname);
676 if(!clone_host)
677 goto out;
678
679 if(cf->conn->bits.conn_to_host) {
680 clone_conn_to_host = strdup(cf->conn->conn_to_host.name);
681 if(!clone_conn_to_host)
682 goto out;
683 }
684
685 if(cf->conn->bits.conn_to_port)
686 conn_to_port = cf->conn->conn_to_port;
687 else
688 conn_to_port = -1;
689
690 /* Now we should add the session ID and the host name to the cache, (remove
691 the oldest if necessary) */
692
693 /* If using shared SSL session, lock! */
694 if(SSLSESSION_SHARED(data)) {
695 general_age = &data->share->sessionage;
696 }
697 else {
698 general_age = &data->state.sessionage;
699 }
700
701 /* find an empty slot for us, or find the oldest */
702 for(i = 1; (i < data->set.general_ssl.max_ssl_sessions) &&
703 data->state.session[i].sessionid; i++) {
704 if(data->state.session[i].age < oldest_age) {
705 oldest_age = data->state.session[i].age;
706 store = &data->state.session[i];
707 }
708 }
709 if(i == data->set.general_ssl.max_ssl_sessions)
710 /* cache is full, we must "kill" the oldest entry! */
711 Curl_ssl_kill_session(store);
712 else
713 store = &data->state.session[i]; /* use this slot */
714
715 /* now init the session struct wisely */
716 if(!clone_ssl_primary_config(conn_config, &store->ssl_config)) {
717 Curl_free_primary_ssl_config(&store->ssl_config);
718 store->sessionid = NULL; /* let caller free sessionid */
719 goto out;
720 }
721 store->sessionid = ssl_sessionid;
722 store->idsize = idsize;
723 store->sessionid_free = sessionid_free_cb;
724 store->age = *general_age; /* set current age */
725 /* free it if there's one already present */
726 free(store->name);
727 free(store->conn_to_host);
728 store->name = clone_host; /* clone host name */
729 clone_host = NULL;
730 store->conn_to_host = clone_conn_to_host; /* clone connect to host name */
731 clone_conn_to_host = NULL;
732 store->conn_to_port = conn_to_port; /* connect to port number */
733 /* port number */
734 store->remote_port = peer->port;
735 store->scheme = cf->conn->handler->scheme;
736 store->transport = peer->transport;
737
738 result = CURLE_OK;
739
740 out:
741 free(clone_host);
742 free(clone_conn_to_host);
743 if(result) {
744 failf(data, "Failed to add Session ID to cache for %s://%s:%d [%s]",
745 store->scheme, store->name, store->remote_port,
746 Curl_ssl_cf_is_proxy(cf) ? "PROXY" : "server");
747 sessionid_free_cb(ssl_sessionid, idsize);
748 return result;
749 }
750 CURL_TRC_CF(data, cf, "Added Session ID to cache for %s://%s:%d [%s]",
751 store->scheme, store->name, store->remote_port,
752 Curl_ssl_cf_is_proxy(cf) ? "PROXY" : "server");
753 return CURLE_OK;
754 }
755
Curl_ssl_close_all(struct Curl_easy * data)756 void Curl_ssl_close_all(struct Curl_easy *data)
757 {
758 /* kill the session ID cache if not shared */
759 if(data->state.session && !SSLSESSION_SHARED(data)) {
760 size_t i;
761 for(i = 0; i < data->set.general_ssl.max_ssl_sessions; i++)
762 /* the single-killer function handles empty table slots */
763 Curl_ssl_kill_session(&data->state.session[i]);
764
765 /* free the cache data */
766 Curl_safefree(data->state.session);
767 }
768
769 Curl_ssl->close_all(data);
770 }
771
Curl_ssl_adjust_pollset(struct Curl_cfilter * cf,struct Curl_easy * data,struct easy_pollset * ps)772 void Curl_ssl_adjust_pollset(struct Curl_cfilter *cf, struct Curl_easy *data,
773 struct easy_pollset *ps)
774 {
775 if(!cf->connected) {
776 struct ssl_connect_data *connssl = cf->ctx;
777 curl_socket_t sock = Curl_conn_cf_get_socket(cf->next, data);
778 if(sock != CURL_SOCKET_BAD) {
779 if(connssl->connecting_state == ssl_connect_2_writing) {
780 Curl_pollset_set_out_only(data, ps, sock);
781 CURL_TRC_CF(data, cf, "adjust_pollset, POLLOUT fd=%"
782 CURL_FORMAT_SOCKET_T, sock);
783 }
784 else {
785 Curl_pollset_set_in_only(data, ps, sock);
786 CURL_TRC_CF(data, cf, "adjust_pollset, POLLIN fd=%"
787 CURL_FORMAT_SOCKET_T, sock);
788 }
789 }
790 }
791 }
792
793 /* Selects an SSL crypto engine
794 */
Curl_ssl_set_engine(struct Curl_easy * data,const char * engine)795 CURLcode Curl_ssl_set_engine(struct Curl_easy *data, const char *engine)
796 {
797 return Curl_ssl->set_engine(data, engine);
798 }
799
800 /* Selects the default SSL crypto engine
801 */
Curl_ssl_set_engine_default(struct Curl_easy * data)802 CURLcode Curl_ssl_set_engine_default(struct Curl_easy *data)
803 {
804 return Curl_ssl->set_engine_default(data);
805 }
806
807 /* Return list of OpenSSL crypto engine names. */
Curl_ssl_engines_list(struct Curl_easy * data)808 struct curl_slist *Curl_ssl_engines_list(struct Curl_easy *data)
809 {
810 return Curl_ssl->engines_list(data);
811 }
812
813 /*
814 * This sets up a session ID cache to the specified size. Make sure this code
815 * is agnostic to what underlying SSL technology we use.
816 */
Curl_ssl_initsessions(struct Curl_easy * data,size_t amount)817 CURLcode Curl_ssl_initsessions(struct Curl_easy *data, size_t amount)
818 {
819 struct Curl_ssl_session *session;
820
821 if(data->state.session)
822 /* this is just a precaution to prevent multiple inits */
823 return CURLE_OK;
824
825 session = calloc(amount, sizeof(struct Curl_ssl_session));
826 if(!session)
827 return CURLE_OUT_OF_MEMORY;
828
829 /* store the info in the SSL section */
830 data->set.general_ssl.max_ssl_sessions = amount;
831 data->state.session = session;
832 data->state.sessionage = 1; /* this is brand new */
833 return CURLE_OK;
834 }
835
836 static size_t multissl_version(char *buffer, size_t size);
837
Curl_ssl_version(char * buffer,size_t size)838 void Curl_ssl_version(char *buffer, size_t size)
839 {
840 #ifdef CURL_WITH_MULTI_SSL
841 (void)multissl_version(buffer, size);
842 #else
843 (void)Curl_ssl->version(buffer, size);
844 #endif
845 }
846
Curl_ssl_free_certinfo(struct Curl_easy * data)847 void Curl_ssl_free_certinfo(struct Curl_easy *data)
848 {
849 struct curl_certinfo *ci = &data->info.certs;
850
851 if(ci->num_of_certs) {
852 /* free all individual lists used */
853 int i;
854 for(i = 0; i<ci->num_of_certs; i++) {
855 curl_slist_free_all(ci->certinfo[i]);
856 ci->certinfo[i] = NULL;
857 }
858
859 free(ci->certinfo); /* free the actual array too */
860 ci->certinfo = NULL;
861 ci->num_of_certs = 0;
862 }
863 }
864
Curl_ssl_init_certinfo(struct Curl_easy * data,int num)865 CURLcode Curl_ssl_init_certinfo(struct Curl_easy *data, int num)
866 {
867 struct curl_certinfo *ci = &data->info.certs;
868 struct curl_slist **table;
869
870 /* Free any previous certificate information structures */
871 Curl_ssl_free_certinfo(data);
872
873 /* Allocate the required certificate information structures */
874 table = calloc((size_t) num, sizeof(struct curl_slist *));
875 if(!table)
876 return CURLE_OUT_OF_MEMORY;
877
878 ci->num_of_certs = num;
879 ci->certinfo = table;
880
881 return CURLE_OK;
882 }
883
884 /*
885 * 'value' is NOT a null-terminated string
886 */
Curl_ssl_push_certinfo_len(struct Curl_easy * data,int certnum,const char * label,const char * value,size_t valuelen)887 CURLcode Curl_ssl_push_certinfo_len(struct Curl_easy *data,
888 int certnum,
889 const char *label,
890 const char *value,
891 size_t valuelen)
892 {
893 struct curl_certinfo *ci = &data->info.certs;
894 struct curl_slist *nl;
895 CURLcode result = CURLE_OK;
896 struct dynbuf build;
897
898 Curl_dyn_init(&build, 10000);
899
900 if(Curl_dyn_add(&build, label) ||
901 Curl_dyn_addn(&build, ":", 1) ||
902 Curl_dyn_addn(&build, value, valuelen))
903 return CURLE_OUT_OF_MEMORY;
904
905 nl = Curl_slist_append_nodup(ci->certinfo[certnum],
906 Curl_dyn_ptr(&build));
907 if(!nl) {
908 Curl_dyn_free(&build);
909 curl_slist_free_all(ci->certinfo[certnum]);
910 result = CURLE_OUT_OF_MEMORY;
911 }
912
913 ci->certinfo[certnum] = nl;
914 return result;
915 }
916
Curl_ssl_random(struct Curl_easy * data,unsigned char * entropy,size_t length)917 CURLcode Curl_ssl_random(struct Curl_easy *data,
918 unsigned char *entropy,
919 size_t length)
920 {
921 return Curl_ssl->random(data, entropy, length);
922 }
923
924 /*
925 * Public key pem to der conversion
926 */
927
pubkey_pem_to_der(const char * pem,unsigned char ** der,size_t * der_len)928 static CURLcode pubkey_pem_to_der(const char *pem,
929 unsigned char **der, size_t *der_len)
930 {
931 char *stripped_pem, *begin_pos, *end_pos;
932 size_t pem_count, stripped_pem_count = 0, pem_len;
933 CURLcode result;
934
935 /* if no pem, exit. */
936 if(!pem)
937 return CURLE_BAD_CONTENT_ENCODING;
938
939 begin_pos = strstr(pem, "-----BEGIN PUBLIC KEY-----");
940 if(!begin_pos)
941 return CURLE_BAD_CONTENT_ENCODING;
942
943 pem_count = begin_pos - pem;
944 /* Invalid if not at beginning AND not directly following \n */
945 if(0 != pem_count && '\n' != pem[pem_count - 1])
946 return CURLE_BAD_CONTENT_ENCODING;
947
948 /* 26 is length of "-----BEGIN PUBLIC KEY-----" */
949 pem_count += 26;
950
951 /* Invalid if not directly following \n */
952 end_pos = strstr(pem + pem_count, "\n-----END PUBLIC KEY-----");
953 if(!end_pos)
954 return CURLE_BAD_CONTENT_ENCODING;
955
956 pem_len = end_pos - pem;
957
958 stripped_pem = malloc(pem_len - pem_count + 1);
959 if(!stripped_pem)
960 return CURLE_OUT_OF_MEMORY;
961
962 /*
963 * Here we loop through the pem array one character at a time between the
964 * correct indices, and place each character that is not '\n' or '\r'
965 * into the stripped_pem array, which should represent the raw base64 string
966 */
967 while(pem_count < pem_len) {
968 if('\n' != pem[pem_count] && '\r' != pem[pem_count])
969 stripped_pem[stripped_pem_count++] = pem[pem_count];
970 ++pem_count;
971 }
972 /* Place the null terminator in the correct place */
973 stripped_pem[stripped_pem_count] = '\0';
974
975 result = Curl_base64_decode(stripped_pem, der, der_len);
976
977 Curl_safefree(stripped_pem);
978
979 return result;
980 }
981
982 /*
983 * Generic pinned public key check.
984 */
985
Curl_pin_peer_pubkey(struct Curl_easy * data,const char * pinnedpubkey,const unsigned char * pubkey,size_t pubkeylen)986 CURLcode Curl_pin_peer_pubkey(struct Curl_easy *data,
987 const char *pinnedpubkey,
988 const unsigned char *pubkey, size_t pubkeylen)
989 {
990 FILE *fp;
991 unsigned char *buf = NULL, *pem_ptr = NULL;
992 CURLcode result = CURLE_SSL_PINNEDPUBKEYNOTMATCH;
993 #ifdef CURL_DISABLE_VERBOSE_STRINGS
994 (void)data;
995 #endif
996
997 /* if a path wasn't specified, don't pin */
998 if(!pinnedpubkey)
999 return CURLE_OK;
1000 if(!pubkey || !pubkeylen)
1001 return result;
1002
1003 /* only do this if pinnedpubkey starts with "sha256//", length 8 */
1004 if(strncmp(pinnedpubkey, "sha256//", 8) == 0) {
1005 CURLcode encode;
1006 size_t encodedlen = 0;
1007 char *encoded = NULL, *pinkeycopy, *begin_pos, *end_pos;
1008 unsigned char *sha256sumdigest;
1009
1010 if(!Curl_ssl->sha256sum) {
1011 /* without sha256 support, this cannot match */
1012 return result;
1013 }
1014
1015 /* compute sha256sum of public key */
1016 sha256sumdigest = malloc(CURL_SHA256_DIGEST_LENGTH);
1017 if(!sha256sumdigest)
1018 return CURLE_OUT_OF_MEMORY;
1019 encode = Curl_ssl->sha256sum(pubkey, pubkeylen,
1020 sha256sumdigest, CURL_SHA256_DIGEST_LENGTH);
1021
1022 if(!encode)
1023 encode = Curl_base64_encode((char *)sha256sumdigest,
1024 CURL_SHA256_DIGEST_LENGTH, &encoded,
1025 &encodedlen);
1026 Curl_safefree(sha256sumdigest);
1027
1028 if(encode)
1029 return encode;
1030
1031 infof(data, " public key hash: sha256//%s", encoded);
1032
1033 /* it starts with sha256//, copy so we can modify it */
1034 pinkeycopy = strdup(pinnedpubkey);
1035 if(!pinkeycopy) {
1036 Curl_safefree(encoded);
1037 return CURLE_OUT_OF_MEMORY;
1038 }
1039 /* point begin_pos to the copy, and start extracting keys */
1040 begin_pos = pinkeycopy;
1041 do {
1042 end_pos = strstr(begin_pos, ";sha256//");
1043 /*
1044 * if there is an end_pos, null terminate,
1045 * otherwise it'll go to the end of the original string
1046 */
1047 if(end_pos)
1048 end_pos[0] = '\0';
1049
1050 /* compare base64 sha256 digests, 8 is the length of "sha256//" */
1051 if(encodedlen == strlen(begin_pos + 8) &&
1052 !memcmp(encoded, begin_pos + 8, encodedlen)) {
1053 result = CURLE_OK;
1054 break;
1055 }
1056
1057 /*
1058 * change back the null-terminator we changed earlier,
1059 * and look for next begin
1060 */
1061 if(end_pos) {
1062 end_pos[0] = ';';
1063 begin_pos = strstr(end_pos, "sha256//");
1064 }
1065 } while(end_pos && begin_pos);
1066 Curl_safefree(encoded);
1067 Curl_safefree(pinkeycopy);
1068 return result;
1069 }
1070
1071 fp = fopen(pinnedpubkey, "rb");
1072 if(!fp)
1073 return result;
1074
1075 do {
1076 long filesize;
1077 size_t size, pem_len;
1078 CURLcode pem_read;
1079
1080 /* Determine the file's size */
1081 if(fseek(fp, 0, SEEK_END))
1082 break;
1083 filesize = ftell(fp);
1084 if(fseek(fp, 0, SEEK_SET))
1085 break;
1086 if(filesize < 0 || filesize > MAX_PINNED_PUBKEY_SIZE)
1087 break;
1088
1089 /*
1090 * if the size of our certificate is bigger than the file
1091 * size then it can't match
1092 */
1093 size = curlx_sotouz((curl_off_t) filesize);
1094 if(pubkeylen > size)
1095 break;
1096
1097 /*
1098 * Allocate buffer for the pinned key
1099 * With 1 additional byte for null terminator in case of PEM key
1100 */
1101 buf = malloc(size + 1);
1102 if(!buf)
1103 break;
1104
1105 /* Returns number of elements read, which should be 1 */
1106 if((int) fread(buf, size, 1, fp) != 1)
1107 break;
1108
1109 /* If the sizes are the same, it can't be base64 encoded, must be der */
1110 if(pubkeylen == size) {
1111 if(!memcmp(pubkey, buf, pubkeylen))
1112 result = CURLE_OK;
1113 break;
1114 }
1115
1116 /*
1117 * Otherwise we will assume it's PEM and try to decode it
1118 * after placing null terminator
1119 */
1120 buf[size] = '\0';
1121 pem_read = pubkey_pem_to_der((const char *)buf, &pem_ptr, &pem_len);
1122 /* if it wasn't read successfully, exit */
1123 if(pem_read)
1124 break;
1125
1126 /*
1127 * if the size of our certificate doesn't match the size of
1128 * the decoded file, they can't be the same, otherwise compare
1129 */
1130 if(pubkeylen == pem_len && !memcmp(pubkey, pem_ptr, pubkeylen))
1131 result = CURLE_OK;
1132 } while(0);
1133
1134 Curl_safefree(buf);
1135 Curl_safefree(pem_ptr);
1136 fclose(fp);
1137
1138 return result;
1139 }
1140
1141 /*
1142 * Check whether the SSL backend supports the status_request extension.
1143 */
Curl_ssl_cert_status_request(void)1144 bool Curl_ssl_cert_status_request(void)
1145 {
1146 return Curl_ssl->cert_status_request();
1147 }
1148
1149 /*
1150 * Check whether the SSL backend supports false start.
1151 */
Curl_ssl_false_start(struct Curl_easy * data)1152 bool Curl_ssl_false_start(struct Curl_easy *data)
1153 {
1154 (void)data;
1155 return Curl_ssl->false_start();
1156 }
1157
1158 /*
1159 * Default implementations for unsupported functions.
1160 */
1161
Curl_none_init(void)1162 int Curl_none_init(void)
1163 {
1164 return 1;
1165 }
1166
Curl_none_cleanup(void)1167 void Curl_none_cleanup(void)
1168 { }
1169
Curl_none_shutdown(struct Curl_cfilter * cf UNUSED_PARAM,struct Curl_easy * data UNUSED_PARAM)1170 int Curl_none_shutdown(struct Curl_cfilter *cf UNUSED_PARAM,
1171 struct Curl_easy *data UNUSED_PARAM)
1172 {
1173 (void)data;
1174 (void)cf;
1175 return 0;
1176 }
1177
Curl_none_check_cxn(struct Curl_cfilter * cf,struct Curl_easy * data)1178 int Curl_none_check_cxn(struct Curl_cfilter *cf, struct Curl_easy *data)
1179 {
1180 (void)cf;
1181 (void)data;
1182 return -1;
1183 }
1184
Curl_none_random(struct Curl_easy * data UNUSED_PARAM,unsigned char * entropy UNUSED_PARAM,size_t length UNUSED_PARAM)1185 CURLcode Curl_none_random(struct Curl_easy *data UNUSED_PARAM,
1186 unsigned char *entropy UNUSED_PARAM,
1187 size_t length UNUSED_PARAM)
1188 {
1189 (void)data;
1190 (void)entropy;
1191 (void)length;
1192 return CURLE_NOT_BUILT_IN;
1193 }
1194
Curl_none_close_all(struct Curl_easy * data UNUSED_PARAM)1195 void Curl_none_close_all(struct Curl_easy *data UNUSED_PARAM)
1196 {
1197 (void)data;
1198 }
1199
Curl_none_session_free(void * ptr UNUSED_PARAM)1200 void Curl_none_session_free(void *ptr UNUSED_PARAM)
1201 {
1202 (void)ptr;
1203 }
1204
Curl_none_data_pending(struct Curl_cfilter * cf UNUSED_PARAM,const struct Curl_easy * data UNUSED_PARAM)1205 bool Curl_none_data_pending(struct Curl_cfilter *cf UNUSED_PARAM,
1206 const struct Curl_easy *data UNUSED_PARAM)
1207 {
1208 (void)cf;
1209 (void)data;
1210 return 0;
1211 }
1212
Curl_none_cert_status_request(void)1213 bool Curl_none_cert_status_request(void)
1214 {
1215 return FALSE;
1216 }
1217
Curl_none_set_engine(struct Curl_easy * data UNUSED_PARAM,const char * engine UNUSED_PARAM)1218 CURLcode Curl_none_set_engine(struct Curl_easy *data UNUSED_PARAM,
1219 const char *engine UNUSED_PARAM)
1220 {
1221 (void)data;
1222 (void)engine;
1223 return CURLE_NOT_BUILT_IN;
1224 }
1225
Curl_none_set_engine_default(struct Curl_easy * data UNUSED_PARAM)1226 CURLcode Curl_none_set_engine_default(struct Curl_easy *data UNUSED_PARAM)
1227 {
1228 (void)data;
1229 return CURLE_NOT_BUILT_IN;
1230 }
1231
Curl_none_engines_list(struct Curl_easy * data UNUSED_PARAM)1232 struct curl_slist *Curl_none_engines_list(struct Curl_easy *data UNUSED_PARAM)
1233 {
1234 (void)data;
1235 return (struct curl_slist *)NULL;
1236 }
1237
Curl_none_false_start(void)1238 bool Curl_none_false_start(void)
1239 {
1240 return FALSE;
1241 }
1242
multissl_init(void)1243 static int multissl_init(void)
1244 {
1245 if(multissl_setup(NULL))
1246 return 1;
1247 return Curl_ssl->init();
1248 }
1249
multissl_connect(struct Curl_cfilter * cf,struct Curl_easy * data)1250 static CURLcode multissl_connect(struct Curl_cfilter *cf,
1251 struct Curl_easy *data)
1252 {
1253 if(multissl_setup(NULL))
1254 return CURLE_FAILED_INIT;
1255 return Curl_ssl->connect_blocking(cf, data);
1256 }
1257
multissl_connect_nonblocking(struct Curl_cfilter * cf,struct Curl_easy * data,bool * done)1258 static CURLcode multissl_connect_nonblocking(struct Curl_cfilter *cf,
1259 struct Curl_easy *data,
1260 bool *done)
1261 {
1262 if(multissl_setup(NULL))
1263 return CURLE_FAILED_INIT;
1264 return Curl_ssl->connect_nonblocking(cf, data, done);
1265 }
1266
multissl_adjust_pollset(struct Curl_cfilter * cf,struct Curl_easy * data,struct easy_pollset * ps)1267 static void multissl_adjust_pollset(struct Curl_cfilter *cf,
1268 struct Curl_easy *data,
1269 struct easy_pollset *ps)
1270 {
1271 if(multissl_setup(NULL))
1272 return;
1273 Curl_ssl->adjust_pollset(cf, data, ps);
1274 }
1275
multissl_get_internals(struct ssl_connect_data * connssl,CURLINFO info)1276 static void *multissl_get_internals(struct ssl_connect_data *connssl,
1277 CURLINFO info)
1278 {
1279 if(multissl_setup(NULL))
1280 return NULL;
1281 return Curl_ssl->get_internals(connssl, info);
1282 }
1283
multissl_close(struct Curl_cfilter * cf,struct Curl_easy * data)1284 static void multissl_close(struct Curl_cfilter *cf, struct Curl_easy *data)
1285 {
1286 if(multissl_setup(NULL))
1287 return;
1288 Curl_ssl->close(cf, data);
1289 }
1290
multissl_recv_plain(struct Curl_cfilter * cf,struct Curl_easy * data,char * buf,size_t len,CURLcode * code)1291 static ssize_t multissl_recv_plain(struct Curl_cfilter *cf,
1292 struct Curl_easy *data,
1293 char *buf, size_t len, CURLcode *code)
1294 {
1295 if(multissl_setup(NULL))
1296 return CURLE_FAILED_INIT;
1297 return Curl_ssl->recv_plain(cf, data, buf, len, code);
1298 }
1299
multissl_send_plain(struct Curl_cfilter * cf,struct Curl_easy * data,const void * mem,size_t len,CURLcode * code)1300 static ssize_t multissl_send_plain(struct Curl_cfilter *cf,
1301 struct Curl_easy *data,
1302 const void *mem, size_t len,
1303 CURLcode *code)
1304 {
1305 if(multissl_setup(NULL))
1306 return CURLE_FAILED_INIT;
1307 return Curl_ssl->send_plain(cf, data, mem, len, code);
1308 }
1309
1310 static const struct Curl_ssl Curl_ssl_multi = {
1311 { CURLSSLBACKEND_NONE, "multi" }, /* info */
1312 0, /* supports nothing */
1313 (size_t)-1, /* something insanely large to be on the safe side */
1314
1315 multissl_init, /* init */
1316 Curl_none_cleanup, /* cleanup */
1317 multissl_version, /* version */
1318 Curl_none_check_cxn, /* check_cxn */
1319 Curl_none_shutdown, /* shutdown */
1320 Curl_none_data_pending, /* data_pending */
1321 Curl_none_random, /* random */
1322 Curl_none_cert_status_request, /* cert_status_request */
1323 multissl_connect, /* connect */
1324 multissl_connect_nonblocking, /* connect_nonblocking */
1325 multissl_adjust_pollset, /* adjust_pollset */
1326 multissl_get_internals, /* get_internals */
1327 multissl_close, /* close_one */
1328 Curl_none_close_all, /* close_all */
1329 Curl_none_set_engine, /* set_engine */
1330 Curl_none_set_engine_default, /* set_engine_default */
1331 Curl_none_engines_list, /* engines_list */
1332 Curl_none_false_start, /* false_start */
1333 NULL, /* sha256sum */
1334 NULL, /* associate_connection */
1335 NULL, /* disassociate_connection */
1336 multissl_recv_plain, /* recv decrypted data */
1337 multissl_send_plain, /* send data to encrypt */
1338 };
1339
1340 const struct Curl_ssl *Curl_ssl =
1341 #if defined(CURL_WITH_MULTI_SSL)
1342 &Curl_ssl_multi;
1343 #elif defined(USE_WOLFSSL)
1344 &Curl_ssl_wolfssl;
1345 #elif defined(USE_SECTRANSP)
1346 &Curl_ssl_sectransp;
1347 #elif defined(USE_GNUTLS)
1348 &Curl_ssl_gnutls;
1349 #elif defined(USE_MBEDTLS)
1350 &Curl_ssl_mbedtls;
1351 #elif defined(USE_RUSTLS)
1352 &Curl_ssl_rustls;
1353 #elif defined(USE_OPENSSL)
1354 &Curl_ssl_openssl;
1355 #elif defined(USE_SCHANNEL)
1356 &Curl_ssl_schannel;
1357 #elif defined(USE_BEARSSL)
1358 &Curl_ssl_bearssl;
1359 #else
1360 #error "Missing struct Curl_ssl for selected SSL backend"
1361 #endif
1362
1363 static const struct Curl_ssl *available_backends[] = {
1364 #if defined(USE_WOLFSSL)
1365 &Curl_ssl_wolfssl,
1366 #endif
1367 #if defined(USE_SECTRANSP)
1368 &Curl_ssl_sectransp,
1369 #endif
1370 #if defined(USE_GNUTLS)
1371 &Curl_ssl_gnutls,
1372 #endif
1373 #if defined(USE_MBEDTLS)
1374 &Curl_ssl_mbedtls,
1375 #endif
1376 #if defined(USE_OPENSSL)
1377 &Curl_ssl_openssl,
1378 #endif
1379 #if defined(USE_SCHANNEL)
1380 &Curl_ssl_schannel,
1381 #endif
1382 #if defined(USE_BEARSSL)
1383 &Curl_ssl_bearssl,
1384 #endif
1385 #if defined(USE_RUSTLS)
1386 &Curl_ssl_rustls,
1387 #endif
1388 NULL
1389 };
1390
multissl_version(char * buffer,size_t size)1391 static size_t multissl_version(char *buffer, size_t size)
1392 {
1393 static const struct Curl_ssl *selected;
1394 static char backends[200];
1395 static size_t backends_len;
1396 const struct Curl_ssl *current;
1397
1398 current = Curl_ssl == &Curl_ssl_multi ? available_backends[0] : Curl_ssl;
1399
1400 if(current != selected) {
1401 char *p = backends;
1402 char *end = backends + sizeof(backends);
1403 int i;
1404
1405 selected = current;
1406
1407 backends[0] = '\0';
1408
1409 for(i = 0; available_backends[i]; ++i) {
1410 char vb[200];
1411 bool paren = (selected != available_backends[i]);
1412
1413 if(available_backends[i]->version(vb, sizeof(vb))) {
1414 p += msnprintf(p, end - p, "%s%s%s%s", (p != backends ? " " : ""),
1415 (paren ? "(" : ""), vb, (paren ? ")" : ""));
1416 }
1417 }
1418
1419 backends_len = p - backends;
1420 }
1421
1422 if(size) {
1423 if(backends_len < size)
1424 strcpy(buffer, backends);
1425 else
1426 *buffer = 0; /* did not fit */
1427 }
1428 return 0;
1429 }
1430
multissl_setup(const struct Curl_ssl * backend)1431 static int multissl_setup(const struct Curl_ssl *backend)
1432 {
1433 const char *env;
1434 char *env_tmp;
1435
1436 if(Curl_ssl != &Curl_ssl_multi)
1437 return 1;
1438
1439 if(backend) {
1440 Curl_ssl = backend;
1441 return 0;
1442 }
1443
1444 if(!available_backends[0])
1445 return 1;
1446
1447 env = env_tmp = curl_getenv("CURL_SSL_BACKEND");
1448 #ifdef CURL_DEFAULT_SSL_BACKEND
1449 if(!env)
1450 env = CURL_DEFAULT_SSL_BACKEND;
1451 #endif
1452 if(env) {
1453 int i;
1454 for(i = 0; available_backends[i]; i++) {
1455 if(strcasecompare(env, available_backends[i]->info.name)) {
1456 Curl_ssl = available_backends[i];
1457 free(env_tmp);
1458 return 0;
1459 }
1460 }
1461 }
1462
1463 /* Fall back to first available backend */
1464 Curl_ssl = available_backends[0];
1465 free(env_tmp);
1466 return 0;
1467 }
1468
1469 /* This function is used to select the SSL backend to use. It is called by
1470 curl_global_sslset (easy.c) which uses the global init lock. */
Curl_init_sslset_nolock(curl_sslbackend id,const char * name,const curl_ssl_backend *** avail)1471 CURLsslset Curl_init_sslset_nolock(curl_sslbackend id, const char *name,
1472 const curl_ssl_backend ***avail)
1473 {
1474 int i;
1475
1476 if(avail)
1477 *avail = (const curl_ssl_backend **)&available_backends;
1478
1479 if(Curl_ssl != &Curl_ssl_multi)
1480 return id == Curl_ssl->info.id ||
1481 (name && strcasecompare(name, Curl_ssl->info.name)) ?
1482 CURLSSLSET_OK :
1483 #if defined(CURL_WITH_MULTI_SSL)
1484 CURLSSLSET_TOO_LATE;
1485 #else
1486 CURLSSLSET_UNKNOWN_BACKEND;
1487 #endif
1488
1489 for(i = 0; available_backends[i]; i++) {
1490 if(available_backends[i]->info.id == id ||
1491 (name && strcasecompare(available_backends[i]->info.name, name))) {
1492 multissl_setup(available_backends[i]);
1493 return CURLSSLSET_OK;
1494 }
1495 }
1496
1497 return CURLSSLSET_UNKNOWN_BACKEND;
1498 }
1499
1500 #else /* USE_SSL */
Curl_init_sslset_nolock(curl_sslbackend id,const char * name,const curl_ssl_backend *** avail)1501 CURLsslset Curl_init_sslset_nolock(curl_sslbackend id, const char *name,
1502 const curl_ssl_backend ***avail)
1503 {
1504 (void)id;
1505 (void)name;
1506 (void)avail;
1507 return CURLSSLSET_NO_BACKENDS;
1508 }
1509
1510 #endif /* !USE_SSL */
1511
1512 #ifdef USE_SSL
1513
Curl_ssl_peer_cleanup(struct ssl_peer * peer)1514 void Curl_ssl_peer_cleanup(struct ssl_peer *peer)
1515 {
1516 if(peer->dispname != peer->hostname)
1517 free(peer->dispname);
1518 free(peer->sni);
1519 free(peer->hostname);
1520 peer->hostname = peer->sni = peer->dispname = NULL;
1521 peer->type = CURL_SSL_PEER_DNS;
1522 }
1523
cf_close(struct Curl_cfilter * cf,struct Curl_easy * data)1524 static void cf_close(struct Curl_cfilter *cf, struct Curl_easy *data)
1525 {
1526 struct ssl_connect_data *connssl = cf->ctx;
1527 if(connssl) {
1528 Curl_ssl->close(cf, data);
1529 connssl->state = ssl_connection_none;
1530 Curl_ssl_peer_cleanup(&connssl->peer);
1531 }
1532 cf->connected = FALSE;
1533 }
1534
get_peer_type(const char * hostname)1535 static ssl_peer_type get_peer_type(const char *hostname)
1536 {
1537 if(hostname && hostname[0]) {
1538 #ifdef USE_IPV6
1539 struct in6_addr addr;
1540 #else
1541 struct in_addr addr;
1542 #endif
1543 if(Curl_inet_pton(AF_INET, hostname, &addr))
1544 return CURL_SSL_PEER_IPV4;
1545 #ifdef USE_IPV6
1546 else if(Curl_inet_pton(AF_INET6, hostname, &addr)) {
1547 return CURL_SSL_PEER_IPV6;
1548 }
1549 #endif
1550 }
1551 return CURL_SSL_PEER_DNS;
1552 }
1553
Curl_ssl_peer_init(struct ssl_peer * peer,struct Curl_cfilter * cf,int transport)1554 CURLcode Curl_ssl_peer_init(struct ssl_peer *peer, struct Curl_cfilter *cf,
1555 int transport)
1556 {
1557 const char *ehostname, *edispname;
1558 int eport;
1559
1560 /* We need the hostname for SNI negotiation. Once handshaked, this
1561 * remains the SNI hostname for the TLS connection. But when the
1562 * connection is reused, the settings in cf->conn might change.
1563 * So we keep a copy of the hostname we use for SNI.
1564 */
1565 #ifndef CURL_DISABLE_PROXY
1566 if(Curl_ssl_cf_is_proxy(cf)) {
1567 ehostname = cf->conn->http_proxy.host.name;
1568 edispname = cf->conn->http_proxy.host.dispname;
1569 eport = cf->conn->http_proxy.port;
1570 }
1571 else
1572 #endif
1573 {
1574 ehostname = cf->conn->host.name;
1575 edispname = cf->conn->host.dispname;
1576 eport = cf->conn->remote_port;
1577 }
1578
1579 /* change if ehostname changed */
1580 DEBUGASSERT(!ehostname || ehostname[0]);
1581 if(ehostname && (!peer->hostname
1582 || strcmp(ehostname, peer->hostname))) {
1583 Curl_ssl_peer_cleanup(peer);
1584 peer->hostname = strdup(ehostname);
1585 if(!peer->hostname) {
1586 Curl_ssl_peer_cleanup(peer);
1587 return CURLE_OUT_OF_MEMORY;
1588 }
1589 if(!edispname || !strcmp(ehostname, edispname))
1590 peer->dispname = peer->hostname;
1591 else {
1592 peer->dispname = strdup(edispname);
1593 if(!peer->dispname) {
1594 Curl_ssl_peer_cleanup(peer);
1595 return CURLE_OUT_OF_MEMORY;
1596 }
1597 }
1598
1599 peer->type = get_peer_type(peer->hostname);
1600 if(peer->type == CURL_SSL_PEER_DNS && peer->hostname[0]) {
1601 /* not an IP address, normalize according to RCC 6066 ch. 3,
1602 * max len of SNI is 2^16-1, no trailing dot */
1603 size_t len = strlen(peer->hostname);
1604 if(len && (peer->hostname[len-1] == '.'))
1605 len--;
1606 if(len < USHRT_MAX) {
1607 peer->sni = calloc(1, len + 1);
1608 if(!peer->sni) {
1609 Curl_ssl_peer_cleanup(peer);
1610 return CURLE_OUT_OF_MEMORY;
1611 }
1612 Curl_strntolower(peer->sni, peer->hostname, len);
1613 peer->sni[len] = 0;
1614 }
1615 }
1616
1617 }
1618 peer->port = eport;
1619 peer->transport = transport;
1620 return CURLE_OK;
1621 }
1622
ssl_cf_destroy(struct Curl_cfilter * cf,struct Curl_easy * data)1623 static void ssl_cf_destroy(struct Curl_cfilter *cf, struct Curl_easy *data)
1624 {
1625 struct cf_call_data save;
1626
1627 CF_DATA_SAVE(save, cf, data);
1628 cf_close(cf, data);
1629 CF_DATA_RESTORE(cf, save);
1630 cf_ctx_free(cf->ctx);
1631 cf->ctx = NULL;
1632 }
1633
ssl_cf_close(struct Curl_cfilter * cf,struct Curl_easy * data)1634 static void ssl_cf_close(struct Curl_cfilter *cf,
1635 struct Curl_easy *data)
1636 {
1637 struct cf_call_data save;
1638
1639 CF_DATA_SAVE(save, cf, data);
1640 cf_close(cf, data);
1641 if(cf->next)
1642 cf->next->cft->do_close(cf->next, data);
1643 CF_DATA_RESTORE(cf, save);
1644 }
1645
ssl_cf_connect(struct Curl_cfilter * cf,struct Curl_easy * data,bool blocking,bool * done)1646 static CURLcode ssl_cf_connect(struct Curl_cfilter *cf,
1647 struct Curl_easy *data,
1648 bool blocking, bool *done)
1649 {
1650 struct ssl_connect_data *connssl = cf->ctx;
1651 struct cf_call_data save;
1652 CURLcode result;
1653
1654 if(cf->connected) {
1655 *done = TRUE;
1656 return CURLE_OK;
1657 }
1658
1659 CF_DATA_SAVE(save, cf, data);
1660 CURL_TRC_CF(data, cf, "cf_connect()");
1661 (void)connssl;
1662 DEBUGASSERT(data->conn);
1663 DEBUGASSERT(data->conn == cf->conn);
1664 DEBUGASSERT(connssl);
1665 DEBUGASSERT(cf->conn->host.name);
1666
1667 result = cf->next->cft->do_connect(cf->next, data, blocking, done);
1668 if(result || !*done)
1669 goto out;
1670
1671 *done = FALSE;
1672 result = Curl_ssl_peer_init(&connssl->peer, cf, TRNSPRT_TCP);
1673 if(result)
1674 goto out;
1675
1676 if(blocking) {
1677 result = ssl_connect(cf, data);
1678 *done = (result == CURLE_OK);
1679 }
1680 else {
1681 result = ssl_connect_nonblocking(cf, data, done);
1682 }
1683
1684 if(!result && *done) {
1685 cf->connected = TRUE;
1686 connssl->handshake_done = Curl_now();
1687 DEBUGASSERT(connssl->state == ssl_connection_complete);
1688 }
1689 out:
1690 CURL_TRC_CF(data, cf, "cf_connect() -> %d, done=%d", result, *done);
1691 CF_DATA_RESTORE(cf, save);
1692 return result;
1693 }
1694
ssl_cf_data_pending(struct Curl_cfilter * cf,const struct Curl_easy * data)1695 static bool ssl_cf_data_pending(struct Curl_cfilter *cf,
1696 const struct Curl_easy *data)
1697 {
1698 struct cf_call_data save;
1699 bool result;
1700
1701 CF_DATA_SAVE(save, cf, data);
1702 if(Curl_ssl->data_pending(cf, data))
1703 result = TRUE;
1704 else
1705 result = cf->next->cft->has_data_pending(cf->next, data);
1706 CF_DATA_RESTORE(cf, save);
1707 return result;
1708 }
1709
ssl_cf_send(struct Curl_cfilter * cf,struct Curl_easy * data,const void * buf,size_t len,CURLcode * err)1710 static ssize_t ssl_cf_send(struct Curl_cfilter *cf,
1711 struct Curl_easy *data, const void *buf, size_t len,
1712 CURLcode *err)
1713 {
1714 struct cf_call_data save;
1715 ssize_t nwritten;
1716
1717 CF_DATA_SAVE(save, cf, data);
1718 *err = CURLE_OK;
1719 nwritten = Curl_ssl->send_plain(cf, data, buf, len, err);
1720 CF_DATA_RESTORE(cf, save);
1721 return nwritten;
1722 }
1723
ssl_cf_recv(struct Curl_cfilter * cf,struct Curl_easy * data,char * buf,size_t len,CURLcode * err)1724 static ssize_t ssl_cf_recv(struct Curl_cfilter *cf,
1725 struct Curl_easy *data, char *buf, size_t len,
1726 CURLcode *err)
1727 {
1728 struct cf_call_data save;
1729 ssize_t nread;
1730
1731 CF_DATA_SAVE(save, cf, data);
1732 *err = CURLE_OK;
1733 nread = Curl_ssl->recv_plain(cf, data, buf, len, err);
1734 if(nread > 0) {
1735 DEBUGASSERT((size_t)nread <= len);
1736 }
1737 else if(nread == 0) {
1738 /* eof */
1739 *err = CURLE_OK;
1740 }
1741 CURL_TRC_CF(data, cf, "cf_recv(len=%zu) -> %zd, %d", len,
1742 nread, *err);
1743 CF_DATA_RESTORE(cf, save);
1744 return nread;
1745 }
1746
ssl_cf_adjust_pollset(struct Curl_cfilter * cf,struct Curl_easy * data,struct easy_pollset * ps)1747 static void ssl_cf_adjust_pollset(struct Curl_cfilter *cf,
1748 struct Curl_easy *data,
1749 struct easy_pollset *ps)
1750 {
1751 struct cf_call_data save;
1752
1753 if(!cf->connected) {
1754 CF_DATA_SAVE(save, cf, data);
1755 Curl_ssl->adjust_pollset(cf, data, ps);
1756 CF_DATA_RESTORE(cf, save);
1757 }
1758 }
1759
ssl_cf_cntrl(struct Curl_cfilter * cf,struct Curl_easy * data,int event,int arg1,void * arg2)1760 static CURLcode ssl_cf_cntrl(struct Curl_cfilter *cf,
1761 struct Curl_easy *data,
1762 int event, int arg1, void *arg2)
1763 {
1764 struct cf_call_data save;
1765
1766 (void)arg1;
1767 (void)arg2;
1768 switch(event) {
1769 case CF_CTRL_DATA_ATTACH:
1770 if(Curl_ssl->attach_data) {
1771 CF_DATA_SAVE(save, cf, data);
1772 Curl_ssl->attach_data(cf, data);
1773 CF_DATA_RESTORE(cf, save);
1774 }
1775 break;
1776 case CF_CTRL_DATA_DETACH:
1777 if(Curl_ssl->detach_data) {
1778 CF_DATA_SAVE(save, cf, data);
1779 Curl_ssl->detach_data(cf, data);
1780 CF_DATA_RESTORE(cf, save);
1781 }
1782 break;
1783 default:
1784 break;
1785 }
1786 return CURLE_OK;
1787 }
1788
ssl_cf_query(struct Curl_cfilter * cf,struct Curl_easy * data,int query,int * pres1,void * pres2)1789 static CURLcode ssl_cf_query(struct Curl_cfilter *cf,
1790 struct Curl_easy *data,
1791 int query, int *pres1, void *pres2)
1792 {
1793 struct ssl_connect_data *connssl = cf->ctx;
1794
1795 switch(query) {
1796 case CF_QUERY_TIMER_APPCONNECT: {
1797 struct curltime *when = pres2;
1798 if(cf->connected && !Curl_ssl_cf_is_proxy(cf))
1799 *when = connssl->handshake_done;
1800 return CURLE_OK;
1801 }
1802 default:
1803 break;
1804 }
1805 return cf->next?
1806 cf->next->cft->query(cf->next, data, query, pres1, pres2) :
1807 CURLE_UNKNOWN_OPTION;
1808 }
1809
cf_ssl_is_alive(struct Curl_cfilter * cf,struct Curl_easy * data,bool * input_pending)1810 static bool cf_ssl_is_alive(struct Curl_cfilter *cf, struct Curl_easy *data,
1811 bool *input_pending)
1812 {
1813 struct cf_call_data save;
1814 int result;
1815 /*
1816 * This function tries to determine connection status.
1817 *
1818 * Return codes:
1819 * 1 means the connection is still in place
1820 * 0 means the connection has been closed
1821 * -1 means the connection status is unknown
1822 */
1823 CF_DATA_SAVE(save, cf, data);
1824 result = Curl_ssl->check_cxn(cf, data);
1825 CF_DATA_RESTORE(cf, save);
1826 if(result > 0) {
1827 *input_pending = TRUE;
1828 return TRUE;
1829 }
1830 if(result == 0) {
1831 *input_pending = FALSE;
1832 return FALSE;
1833 }
1834 /* ssl backend does not know */
1835 return cf->next?
1836 cf->next->cft->is_alive(cf->next, data, input_pending) :
1837 FALSE; /* pessimistic in absence of data */
1838 }
1839
1840 struct Curl_cftype Curl_cft_ssl = {
1841 "SSL",
1842 CF_TYPE_SSL,
1843 CURL_LOG_LVL_NONE,
1844 ssl_cf_destroy,
1845 ssl_cf_connect,
1846 ssl_cf_close,
1847 Curl_cf_def_get_host,
1848 ssl_cf_adjust_pollset,
1849 ssl_cf_data_pending,
1850 ssl_cf_send,
1851 ssl_cf_recv,
1852 ssl_cf_cntrl,
1853 cf_ssl_is_alive,
1854 Curl_cf_def_conn_keep_alive,
1855 ssl_cf_query,
1856 };
1857
1858 #ifndef CURL_DISABLE_PROXY
1859
1860 struct Curl_cftype Curl_cft_ssl_proxy = {
1861 "SSL-PROXY",
1862 CF_TYPE_SSL|CF_TYPE_PROXY,
1863 CURL_LOG_LVL_NONE,
1864 ssl_cf_destroy,
1865 ssl_cf_connect,
1866 ssl_cf_close,
1867 Curl_cf_def_get_host,
1868 ssl_cf_adjust_pollset,
1869 ssl_cf_data_pending,
1870 ssl_cf_send,
1871 ssl_cf_recv,
1872 ssl_cf_cntrl,
1873 cf_ssl_is_alive,
1874 Curl_cf_def_conn_keep_alive,
1875 Curl_cf_def_query,
1876 };
1877
1878 #endif /* !CURL_DISABLE_PROXY */
1879
cf_ssl_create(struct Curl_cfilter ** pcf,struct Curl_easy * data,struct connectdata * conn)1880 static CURLcode cf_ssl_create(struct Curl_cfilter **pcf,
1881 struct Curl_easy *data,
1882 struct connectdata *conn)
1883 {
1884 struct Curl_cfilter *cf = NULL;
1885 struct ssl_connect_data *ctx;
1886 CURLcode result;
1887
1888 DEBUGASSERT(data->conn);
1889
1890 ctx = cf_ctx_new(data, alpn_get_spec(data->state.httpwant,
1891 conn->bits.tls_enable_alpn));
1892 if(!ctx) {
1893 result = CURLE_OUT_OF_MEMORY;
1894 goto out;
1895 }
1896
1897 result = Curl_cf_create(&cf, &Curl_cft_ssl, ctx);
1898
1899 out:
1900 if(result)
1901 cf_ctx_free(ctx);
1902 *pcf = result? NULL : cf;
1903 return result;
1904 }
1905
Curl_ssl_cfilter_add(struct Curl_easy * data,struct connectdata * conn,int sockindex)1906 CURLcode Curl_ssl_cfilter_add(struct Curl_easy *data,
1907 struct connectdata *conn,
1908 int sockindex)
1909 {
1910 struct Curl_cfilter *cf;
1911 CURLcode result;
1912
1913 result = cf_ssl_create(&cf, data, conn);
1914 if(!result)
1915 Curl_conn_cf_add(data, conn, sockindex, cf);
1916 return result;
1917 }
1918
Curl_cf_ssl_insert_after(struct Curl_cfilter * cf_at,struct Curl_easy * data)1919 CURLcode Curl_cf_ssl_insert_after(struct Curl_cfilter *cf_at,
1920 struct Curl_easy *data)
1921 {
1922 struct Curl_cfilter *cf;
1923 CURLcode result;
1924
1925 result = cf_ssl_create(&cf, data, cf_at->conn);
1926 if(!result)
1927 Curl_conn_cf_insert_after(cf_at, cf);
1928 return result;
1929 }
1930
1931 #ifndef CURL_DISABLE_PROXY
1932
cf_ssl_proxy_create(struct Curl_cfilter ** pcf,struct Curl_easy * data,struct connectdata * conn)1933 static CURLcode cf_ssl_proxy_create(struct Curl_cfilter **pcf,
1934 struct Curl_easy *data,
1935 struct connectdata *conn)
1936 {
1937 struct Curl_cfilter *cf = NULL;
1938 struct ssl_connect_data *ctx;
1939 CURLcode result;
1940 bool use_alpn = conn->bits.tls_enable_alpn;
1941 int httpwant = CURL_HTTP_VERSION_1_1;
1942
1943 #ifdef USE_HTTP2
1944 if(conn->http_proxy.proxytype == CURLPROXY_HTTPS2) {
1945 use_alpn = TRUE;
1946 httpwant = CURL_HTTP_VERSION_2;
1947 }
1948 #endif
1949
1950 ctx = cf_ctx_new(data, alpn_get_spec(httpwant, use_alpn));
1951 if(!ctx) {
1952 result = CURLE_OUT_OF_MEMORY;
1953 goto out;
1954 }
1955 result = Curl_cf_create(&cf, &Curl_cft_ssl_proxy, ctx);
1956
1957 out:
1958 if(result)
1959 cf_ctx_free(ctx);
1960 *pcf = result? NULL : cf;
1961 return result;
1962 }
1963
Curl_cf_ssl_proxy_insert_after(struct Curl_cfilter * cf_at,struct Curl_easy * data)1964 CURLcode Curl_cf_ssl_proxy_insert_after(struct Curl_cfilter *cf_at,
1965 struct Curl_easy *data)
1966 {
1967 struct Curl_cfilter *cf;
1968 CURLcode result;
1969
1970 result = cf_ssl_proxy_create(&cf, data, cf_at->conn);
1971 if(!result)
1972 Curl_conn_cf_insert_after(cf_at, cf);
1973 return result;
1974 }
1975
1976 #endif /* !CURL_DISABLE_PROXY */
1977
Curl_ssl_supports(struct Curl_easy * data,int option)1978 bool Curl_ssl_supports(struct Curl_easy *data, int option)
1979 {
1980 (void)data;
1981 return (Curl_ssl->supports & option)? TRUE : FALSE;
1982 }
1983
get_ssl_filter(struct Curl_cfilter * cf)1984 static struct Curl_cfilter *get_ssl_filter(struct Curl_cfilter *cf)
1985 {
1986 for(; cf; cf = cf->next) {
1987 if(cf->cft == &Curl_cft_ssl)
1988 return cf;
1989 #ifndef CURL_DISABLE_PROXY
1990 if(cf->cft == &Curl_cft_ssl_proxy)
1991 return cf;
1992 #endif
1993 }
1994 return NULL;
1995 }
1996
1997
Curl_ssl_get_internals(struct Curl_easy * data,int sockindex,CURLINFO info,int n)1998 void *Curl_ssl_get_internals(struct Curl_easy *data, int sockindex,
1999 CURLINFO info, int n)
2000 {
2001 void *result = NULL;
2002 (void)n;
2003 if(data->conn) {
2004 struct Curl_cfilter *cf;
2005 /* get first SSL filter in chain, if any is present */
2006 cf = get_ssl_filter(data->conn->cfilter[sockindex]);
2007 if(cf) {
2008 struct cf_call_data save;
2009 CF_DATA_SAVE(save, cf, data);
2010 result = Curl_ssl->get_internals(cf->ctx, info);
2011 CF_DATA_RESTORE(cf, save);
2012 }
2013 }
2014 return result;
2015 }
2016
Curl_ssl_cfilter_remove(struct Curl_easy * data,int sockindex)2017 CURLcode Curl_ssl_cfilter_remove(struct Curl_easy *data,
2018 int sockindex)
2019 {
2020 struct Curl_cfilter *cf, *head;
2021 CURLcode result = CURLE_OK;
2022
2023 (void)data;
2024 head = data->conn? data->conn->cfilter[sockindex] : NULL;
2025 for(cf = head; cf; cf = cf->next) {
2026 if(cf->cft == &Curl_cft_ssl) {
2027 if(Curl_ssl->shut_down(cf, data))
2028 result = CURLE_SSL_SHUTDOWN_FAILED;
2029 Curl_conn_cf_discard_sub(head, cf, data, FALSE);
2030 break;
2031 }
2032 }
2033 return result;
2034 }
2035
Curl_ssl_cf_is_proxy(struct Curl_cfilter * cf)2036 bool Curl_ssl_cf_is_proxy(struct Curl_cfilter *cf)
2037 {
2038 return (cf->cft->flags & CF_TYPE_SSL) && (cf->cft->flags & CF_TYPE_PROXY);
2039 }
2040
2041 struct ssl_config_data *
Curl_ssl_cf_get_config(struct Curl_cfilter * cf,struct Curl_easy * data)2042 Curl_ssl_cf_get_config(struct Curl_cfilter *cf, struct Curl_easy *data)
2043 {
2044 #ifdef CURL_DISABLE_PROXY
2045 (void)cf;
2046 return &data->set.ssl;
2047 #else
2048 return Curl_ssl_cf_is_proxy(cf)? &data->set.proxy_ssl : &data->set.ssl;
2049 #endif
2050 }
2051
2052 struct ssl_primary_config *
Curl_ssl_cf_get_primary_config(struct Curl_cfilter * cf)2053 Curl_ssl_cf_get_primary_config(struct Curl_cfilter *cf)
2054 {
2055 #ifdef CURL_DISABLE_PROXY
2056 return &cf->conn->ssl_config;
2057 #else
2058 return Curl_ssl_cf_is_proxy(cf)?
2059 &cf->conn->proxy_ssl_config : &cf->conn->ssl_config;
2060 #endif
2061 }
2062
Curl_alpn_to_proto_buf(struct alpn_proto_buf * buf,const struct alpn_spec * spec)2063 CURLcode Curl_alpn_to_proto_buf(struct alpn_proto_buf *buf,
2064 const struct alpn_spec *spec)
2065 {
2066 size_t i, len;
2067 int off = 0;
2068 unsigned char blen;
2069
2070 memset(buf, 0, sizeof(*buf));
2071 for(i = 0; spec && i < spec->count; ++i) {
2072 len = strlen(spec->entries[i]);
2073 if(len >= ALPN_NAME_MAX)
2074 return CURLE_FAILED_INIT;
2075 blen = (unsigned char)len;
2076 if(off + blen + 1 >= (int)sizeof(buf->data))
2077 return CURLE_FAILED_INIT;
2078 buf->data[off++] = blen;
2079 memcpy(buf->data + off, spec->entries[i], blen);
2080 off += blen;
2081 }
2082 buf->len = off;
2083 return CURLE_OK;
2084 }
2085
Curl_alpn_to_proto_str(struct alpn_proto_buf * buf,const struct alpn_spec * spec)2086 CURLcode Curl_alpn_to_proto_str(struct alpn_proto_buf *buf,
2087 const struct alpn_spec *spec)
2088 {
2089 size_t i, len;
2090 size_t off = 0;
2091
2092 memset(buf, 0, sizeof(*buf));
2093 for(i = 0; spec && i < spec->count; ++i) {
2094 len = strlen(spec->entries[i]);
2095 if(len >= ALPN_NAME_MAX)
2096 return CURLE_FAILED_INIT;
2097 if(off + len + 2 >= sizeof(buf->data))
2098 return CURLE_FAILED_INIT;
2099 if(off)
2100 buf->data[off++] = ',';
2101 memcpy(buf->data + off, spec->entries[i], len);
2102 off += len;
2103 }
2104 buf->data[off] = '\0';
2105 buf->len = (int)off;
2106 return CURLE_OK;
2107 }
2108
Curl_alpn_set_negotiated(struct Curl_cfilter * cf,struct Curl_easy * data,const unsigned char * proto,size_t proto_len)2109 CURLcode Curl_alpn_set_negotiated(struct Curl_cfilter *cf,
2110 struct Curl_easy *data,
2111 const unsigned char *proto,
2112 size_t proto_len)
2113 {
2114 int can_multi = 0;
2115 unsigned char *palpn =
2116 #ifndef CURL_DISABLE_PROXY
2117 (cf->conn->bits.tunnel_proxy && Curl_ssl_cf_is_proxy(cf))?
2118 &cf->conn->proxy_alpn : &cf->conn->alpn
2119 #else
2120 &cf->conn->alpn
2121 #endif
2122 ;
2123
2124 if(proto && proto_len) {
2125 if(proto_len == ALPN_HTTP_1_1_LENGTH &&
2126 !memcmp(ALPN_HTTP_1_1, proto, ALPN_HTTP_1_1_LENGTH)) {
2127 *palpn = CURL_HTTP_VERSION_1_1;
2128 }
2129 #ifdef USE_HTTP2
2130 else if(proto_len == ALPN_H2_LENGTH &&
2131 !memcmp(ALPN_H2, proto, ALPN_H2_LENGTH)) {
2132 *palpn = CURL_HTTP_VERSION_2;
2133 can_multi = 1;
2134 }
2135 #endif
2136 #ifdef USE_HTTP3
2137 else if(proto_len == ALPN_H3_LENGTH &&
2138 !memcmp(ALPN_H3, proto, ALPN_H3_LENGTH)) {
2139 *palpn = CURL_HTTP_VERSION_3;
2140 can_multi = 1;
2141 }
2142 #endif
2143 else {
2144 *palpn = CURL_HTTP_VERSION_NONE;
2145 failf(data, "unsupported ALPN protocol: '%.*s'", (int)proto_len, proto);
2146 /* TODO: do we want to fail this? Previous code just ignored it and
2147 * some vtls backends even ignore the return code of this function. */
2148 /* return CURLE_NOT_BUILT_IN; */
2149 goto out;
2150 }
2151 infof(data, VTLS_INFOF_ALPN_ACCEPTED_LEN_1STR, (int)proto_len, proto);
2152 }
2153 else {
2154 *palpn = CURL_HTTP_VERSION_NONE;
2155 infof(data, VTLS_INFOF_NO_ALPN);
2156 }
2157
2158 out:
2159 if(!Curl_ssl_cf_is_proxy(cf))
2160 Curl_multiuse_state(data, can_multi?
2161 BUNDLE_MULTIPLEX : BUNDLE_NO_MULTIUSE);
2162 return CURLE_OK;
2163 }
2164
2165 #endif /* USE_SSL */
2166