diff options
Diffstat (limited to 'src/lib/libssl/ssl_sess.c')
-rw-r--r-- | src/lib/libssl/ssl_sess.c | 1143 |
1 files changed, 1143 insertions, 0 deletions
diff --git a/src/lib/libssl/ssl_sess.c b/src/lib/libssl/ssl_sess.c new file mode 100644 index 0000000000..b29115862b --- /dev/null +++ b/src/lib/libssl/ssl_sess.c | |||
@@ -0,0 +1,1143 @@ | |||
1 | /* ssl/ssl_sess.c */ | ||
2 | /* Copyright (C) 1995-1998 Eric Young (eay@cryptsoft.com) | ||
3 | * All rights reserved. | ||
4 | * | ||
5 | * This package is an SSL implementation written | ||
6 | * by Eric Young (eay@cryptsoft.com). | ||
7 | * The implementation was written so as to conform with Netscapes SSL. | ||
8 | * | ||
9 | * This library is free for commercial and non-commercial use as long as | ||
10 | * the following conditions are aheared to. The following conditions | ||
11 | * apply to all code found in this distribution, be it the RC4, RSA, | ||
12 | * lhash, DES, etc., code; not just the SSL code. The SSL documentation | ||
13 | * included with this distribution is covered by the same copyright terms | ||
14 | * except that the holder is Tim Hudson (tjh@cryptsoft.com). | ||
15 | * | ||
16 | * Copyright remains Eric Young's, and as such any Copyright notices in | ||
17 | * the code are not to be removed. | ||
18 | * If this package is used in a product, Eric Young should be given attribution | ||
19 | * as the author of the parts of the library used. | ||
20 | * This can be in the form of a textual message at program startup or | ||
21 | * in documentation (online or textual) provided with the package. | ||
22 | * | ||
23 | * Redistribution and use in source and binary forms, with or without | ||
24 | * modification, are permitted provided that the following conditions | ||
25 | * are met: | ||
26 | * 1. Redistributions of source code must retain the copyright | ||
27 | * notice, this list of conditions and the following disclaimer. | ||
28 | * 2. Redistributions in binary form must reproduce the above copyright | ||
29 | * notice, this list of conditions and the following disclaimer in the | ||
30 | * documentation and/or other materials provided with the distribution. | ||
31 | * 3. All advertising materials mentioning features or use of this software | ||
32 | * must display the following acknowledgement: | ||
33 | * "This product includes cryptographic software written by | ||
34 | * Eric Young (eay@cryptsoft.com)" | ||
35 | * The word 'cryptographic' can be left out if the rouines from the library | ||
36 | * being used are not cryptographic related :-). | ||
37 | * 4. If you include any Windows specific code (or a derivative thereof) from | ||
38 | * the apps directory (application code) you must include an acknowledgement: | ||
39 | * "This product includes software written by Tim Hudson (tjh@cryptsoft.com)" | ||
40 | * | ||
41 | * THIS SOFTWARE IS PROVIDED BY ERIC YOUNG ``AS IS'' AND | ||
42 | * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE | ||
43 | * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE | ||
44 | * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE | ||
45 | * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL | ||
46 | * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS | ||
47 | * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) | ||
48 | * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT | ||
49 | * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY | ||
50 | * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF | ||
51 | * SUCH DAMAGE. | ||
52 | * | ||
53 | * The licence and distribution terms for any publically available version or | ||
54 | * derivative of this code cannot be changed. i.e. this code cannot simply be | ||
55 | * copied and put under another distribution licence | ||
56 | * [including the GNU Public Licence.] | ||
57 | */ | ||
58 | /* ==================================================================== | ||
59 | * Copyright (c) 1998-2006 The OpenSSL Project. All rights reserved. | ||
60 | * | ||
61 | * Redistribution and use in source and binary forms, with or without | ||
62 | * modification, are permitted provided that the following conditions | ||
63 | * are met: | ||
64 | * | ||
65 | * 1. Redistributions of source code must retain the above copyright | ||
66 | * notice, this list of conditions and the following disclaimer. | ||
67 | * | ||
68 | * 2. Redistributions in binary form must reproduce the above copyright | ||
69 | * notice, this list of conditions and the following disclaimer in | ||
70 | * the documentation and/or other materials provided with the | ||
71 | * distribution. | ||
72 | * | ||
73 | * 3. All advertising materials mentioning features or use of this | ||
74 | * software must display the following acknowledgment: | ||
75 | * "This product includes software developed by the OpenSSL Project | ||
76 | * for use in the OpenSSL Toolkit. (http://www.openssl.org/)" | ||
77 | * | ||
78 | * 4. The names "OpenSSL Toolkit" and "OpenSSL Project" must not be used to | ||
79 | * endorse or promote products derived from this software without | ||
80 | * prior written permission. For written permission, please contact | ||
81 | * openssl-core@openssl.org. | ||
82 | * | ||
83 | * 5. Products derived from this software may not be called "OpenSSL" | ||
84 | * nor may "OpenSSL" appear in their names without prior written | ||
85 | * permission of the OpenSSL Project. | ||
86 | * | ||
87 | * 6. Redistributions of any form whatsoever must retain the following | ||
88 | * acknowledgment: | ||
89 | * "This product includes software developed by the OpenSSL Project | ||
90 | * for use in the OpenSSL Toolkit (http://www.openssl.org/)" | ||
91 | * | ||
92 | * THIS SOFTWARE IS PROVIDED BY THE OpenSSL PROJECT ``AS IS'' AND ANY | ||
93 | * EXPRESSED OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE | ||
94 | * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR | ||
95 | * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE OpenSSL PROJECT OR | ||
96 | * ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, | ||
97 | * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT | ||
98 | * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; | ||
99 | * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) | ||
100 | * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, | ||
101 | * STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) | ||
102 | * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED | ||
103 | * OF THE POSSIBILITY OF SUCH DAMAGE. | ||
104 | * ==================================================================== | ||
105 | * | ||
106 | * This product includes cryptographic software written by Eric Young | ||
107 | * (eay@cryptsoft.com). This product includes software written by Tim | ||
108 | * Hudson (tjh@cryptsoft.com). | ||
109 | * | ||
110 | */ | ||
111 | /* ==================================================================== | ||
112 | * Copyright 2005 Nokia. All rights reserved. | ||
113 | * | ||
114 | * The portions of the attached software ("Contribution") is developed by | ||
115 | * Nokia Corporation and is licensed pursuant to the OpenSSL open source | ||
116 | * license. | ||
117 | * | ||
118 | * The Contribution, originally written by Mika Kousa and Pasi Eronen of | ||
119 | * Nokia Corporation, consists of the "PSK" (Pre-Shared Key) ciphersuites | ||
120 | * support (see RFC 4279) to OpenSSL. | ||
121 | * | ||
122 | * No patent licenses or other rights except those expressly stated in | ||
123 | * the OpenSSL open source license shall be deemed granted or received | ||
124 | * expressly, by implication, estoppel, or otherwise. | ||
125 | * | ||
126 | * No assurances are provided by Nokia that the Contribution does not | ||
127 | * infringe the patent or other intellectual property rights of any third | ||
128 | * party or that the license provides you with all the necessary rights | ||
129 | * to make use of the Contribution. | ||
130 | * | ||
131 | * THE SOFTWARE IS PROVIDED "AS IS" WITHOUT WARRANTY OF ANY KIND. IN | ||
132 | * ADDITION TO THE DISCLAIMERS INCLUDED IN THE LICENSE, NOKIA | ||
133 | * SPECIFICALLY DISCLAIMS ANY LIABILITY FOR CLAIMS BROUGHT BY YOU OR ANY | ||
134 | * OTHER ENTITY BASED ON INFRINGEMENT OF INTELLECTUAL PROPERTY RIGHTS OR | ||
135 | * OTHERWISE. | ||
136 | */ | ||
137 | |||
138 | #include <stdio.h> | ||
139 | #include <openssl/lhash.h> | ||
140 | #include <openssl/rand.h> | ||
141 | #ifndef OPENSSL_NO_ENGINE | ||
142 | #include <openssl/engine.h> | ||
143 | #endif | ||
144 | #include "ssl_locl.h" | ||
145 | |||
146 | static void SSL_SESSION_list_remove(SSL_CTX *ctx, SSL_SESSION *s); | ||
147 | static void SSL_SESSION_list_add(SSL_CTX *ctx, SSL_SESSION *s); | ||
148 | static int remove_session_lock(SSL_CTX *ctx, SSL_SESSION *c, int lck); | ||
149 | |||
150 | SSL_SESSION | ||
151 | *SSL_get_session(const SSL *ssl) | ||
152 | /* aka SSL_get0_session; gets 0 objects, just returns a copy of the pointer */ | ||
153 | { | ||
154 | return (ssl->session); | ||
155 | } | ||
156 | |||
157 | SSL_SESSION | ||
158 | *SSL_get1_session(SSL *ssl) | ||
159 | /* variant of SSL_get_session: caller really gets something */ | ||
160 | { | ||
161 | SSL_SESSION *sess; | ||
162 | /* Need to lock this all up rather than just use CRYPTO_add so that | ||
163 | * somebody doesn't free ssl->session between when we check it's | ||
164 | * non-null and when we up the reference count. */ | ||
165 | CRYPTO_w_lock(CRYPTO_LOCK_SSL_SESSION); | ||
166 | sess = ssl->session; | ||
167 | if (sess) | ||
168 | sess->references++; | ||
169 | CRYPTO_w_unlock(CRYPTO_LOCK_SSL_SESSION); | ||
170 | return (sess); | ||
171 | } | ||
172 | |||
173 | int | ||
174 | SSL_SESSION_get_ex_new_index(long argl, void *argp, CRYPTO_EX_new *new_func, | ||
175 | CRYPTO_EX_dup *dup_func, CRYPTO_EX_free *free_func) | ||
176 | { | ||
177 | return CRYPTO_get_ex_new_index(CRYPTO_EX_INDEX_SSL_SESSION, argl, argp, | ||
178 | new_func, dup_func, free_func); | ||
179 | } | ||
180 | |||
181 | int | ||
182 | SSL_SESSION_set_ex_data(SSL_SESSION *s, int idx, void *arg) | ||
183 | { | ||
184 | return (CRYPTO_set_ex_data(&s->ex_data, idx, arg)); | ||
185 | } | ||
186 | |||
187 | void | ||
188 | *SSL_SESSION_get_ex_data(const SSL_SESSION *s, int idx) | ||
189 | { | ||
190 | return (CRYPTO_get_ex_data(&s->ex_data, idx)); | ||
191 | } | ||
192 | |||
193 | SSL_SESSION | ||
194 | *SSL_SESSION_new(void) | ||
195 | { | ||
196 | SSL_SESSION *ss; | ||
197 | |||
198 | ss = (SSL_SESSION *)OPENSSL_malloc(sizeof(SSL_SESSION)); | ||
199 | if (ss == NULL) { | ||
200 | SSLerr(SSL_F_SSL_SESSION_NEW, ERR_R_MALLOC_FAILURE); | ||
201 | return (0); | ||
202 | } | ||
203 | memset(ss, 0, sizeof(SSL_SESSION)); | ||
204 | |||
205 | ss->verify_result = 1; /* avoid 0 (= X509_V_OK) just in case */ | ||
206 | ss->references = 1; | ||
207 | ss->timeout=60*5+4; /* 5 minute timeout by default */ | ||
208 | ss->time = (unsigned long)time(NULL); | ||
209 | ss->prev = NULL; | ||
210 | ss->next = NULL; | ||
211 | ss->compress_meth = 0; | ||
212 | #ifndef OPENSSL_NO_TLSEXT | ||
213 | ss->tlsext_hostname = NULL; | ||
214 | |||
215 | #ifndef OPENSSL_NO_EC | ||
216 | ss->tlsext_ecpointformatlist_length = 0; | ||
217 | ss->tlsext_ecpointformatlist = NULL; | ||
218 | ss->tlsext_ellipticcurvelist_length = 0; | ||
219 | ss->tlsext_ellipticcurvelist = NULL; | ||
220 | #endif | ||
221 | #endif | ||
222 | CRYPTO_new_ex_data(CRYPTO_EX_INDEX_SSL_SESSION, ss, &ss->ex_data); | ||
223 | #ifndef OPENSSL_NO_PSK | ||
224 | ss->psk_identity_hint = NULL; | ||
225 | ss->psk_identity = NULL; | ||
226 | #endif | ||
227 | #ifndef OPENSSL_NO_SRP | ||
228 | ss->srp_username = NULL; | ||
229 | #endif | ||
230 | return (ss); | ||
231 | } | ||
232 | |||
233 | const unsigned char | ||
234 | *SSL_SESSION_get_id(const SSL_SESSION *s, unsigned int *len) | ||
235 | { | ||
236 | if (len) | ||
237 | *len = s->session_id_length; | ||
238 | return s->session_id; | ||
239 | } | ||
240 | |||
241 | unsigned int | ||
242 | SSL_SESSION_get_compress_id(const SSL_SESSION *s) | ||
243 | { | ||
244 | return s->compress_meth; | ||
245 | } | ||
246 | |||
247 | /* Even with SSLv2, we have 16 bytes (128 bits) of session ID space. SSLv3/TLSv1 | ||
248 | * has 32 bytes (256 bits). As such, filling the ID with random gunk repeatedly | ||
249 | * until we have no conflict is going to complete in one iteration pretty much | ||
250 | * "most" of the time (btw: understatement). So, if it takes us 10 iterations | ||
251 | * and we still can't avoid a conflict - well that's a reasonable point to call | ||
252 | * it quits. Either the RAND code is broken or someone is trying to open roughly | ||
253 | * very close to 2^128 (or 2^256) SSL sessions to our server. How you might | ||
254 | * store that many sessions is perhaps a more interesting question ... */ | ||
255 | |||
256 | #define MAX_SESS_ID_ATTEMPTS 10 | ||
257 | static int | ||
258 | def_generate_session_id(const SSL *ssl, unsigned char *id, | ||
259 | unsigned int *id_len) | ||
260 | { | ||
261 | unsigned int retry = 0; | ||
262 | do | ||
263 | if (RAND_pseudo_bytes(id, *id_len) <= 0) | ||
264 | return 0; | ||
265 | while (SSL_has_matching_session_id(ssl, id, *id_len) && | ||
266 | (++retry < MAX_SESS_ID_ATTEMPTS)); | ||
267 | if (retry < MAX_SESS_ID_ATTEMPTS) | ||
268 | return 1; | ||
269 | /* else - woops a session_id match */ | ||
270 | /* XXX We should also check the external cache -- | ||
271 | * but the probability of a collision is negligible, and | ||
272 | * we could not prevent the concurrent creation of sessions | ||
273 | * with identical IDs since we currently don't have means | ||
274 | * to atomically check whether a session ID already exists | ||
275 | * and make a reservation for it if it does not | ||
276 | * (this problem applies to the internal cache as well). | ||
277 | */ | ||
278 | return 0; | ||
279 | } | ||
280 | |||
281 | int | ||
282 | ssl_get_new_session(SSL *s, int session) | ||
283 | { | ||
284 | /* This gets used by clients and servers. */ | ||
285 | |||
286 | unsigned int tmp; | ||
287 | SSL_SESSION *ss = NULL; | ||
288 | GEN_SESSION_CB cb = def_generate_session_id; | ||
289 | |||
290 | if ((ss = SSL_SESSION_new()) == NULL) return (0); | ||
291 | |||
292 | /* If the context has a default timeout, use it */ | ||
293 | if (s->session_ctx->session_timeout == 0) | ||
294 | ss->timeout = SSL_get_default_timeout(s); | ||
295 | else | ||
296 | ss->timeout = s->session_ctx->session_timeout; | ||
297 | |||
298 | if (s->session != NULL) { | ||
299 | SSL_SESSION_free(s->session); | ||
300 | s->session = NULL; | ||
301 | } | ||
302 | |||
303 | if (session) { | ||
304 | if (s->version == SSL2_VERSION) { | ||
305 | ss->ssl_version = SSL2_VERSION; | ||
306 | ss->session_id_length = SSL2_SSL_SESSION_ID_LENGTH; | ||
307 | } else if (s->version == SSL3_VERSION) { | ||
308 | ss->ssl_version = SSL3_VERSION; | ||
309 | ss->session_id_length = SSL3_SSL_SESSION_ID_LENGTH; | ||
310 | } else if (s->version == TLS1_VERSION) { | ||
311 | ss->ssl_version = TLS1_VERSION; | ||
312 | ss->session_id_length = SSL3_SSL_SESSION_ID_LENGTH; | ||
313 | } else if (s->version == TLS1_1_VERSION) { | ||
314 | ss->ssl_version = TLS1_1_VERSION; | ||
315 | ss->session_id_length = SSL3_SSL_SESSION_ID_LENGTH; | ||
316 | } else if (s->version == TLS1_2_VERSION) { | ||
317 | ss->ssl_version = TLS1_2_VERSION; | ||
318 | ss->session_id_length = SSL3_SSL_SESSION_ID_LENGTH; | ||
319 | } else if (s->version == DTLS1_BAD_VER) { | ||
320 | ss->ssl_version = DTLS1_BAD_VER; | ||
321 | ss->session_id_length = SSL3_SSL_SESSION_ID_LENGTH; | ||
322 | } else if (s->version == DTLS1_VERSION) { | ||
323 | ss->ssl_version = DTLS1_VERSION; | ||
324 | ss->session_id_length = SSL3_SSL_SESSION_ID_LENGTH; | ||
325 | } else { | ||
326 | SSLerr(SSL_F_SSL_GET_NEW_SESSION, SSL_R_UNSUPPORTED_SSL_VERSION); | ||
327 | SSL_SESSION_free(ss); | ||
328 | return (0); | ||
329 | } | ||
330 | #ifndef OPENSSL_NO_TLSEXT | ||
331 | /* If RFC4507 ticket use empty session ID */ | ||
332 | if (s->tlsext_ticket_expected) { | ||
333 | ss->session_id_length = 0; | ||
334 | goto sess_id_done; | ||
335 | } | ||
336 | #endif | ||
337 | /* Choose which callback will set the session ID */ | ||
338 | CRYPTO_r_lock(CRYPTO_LOCK_SSL_CTX); | ||
339 | if (s->generate_session_id) | ||
340 | cb = s->generate_session_id; | ||
341 | else if (s->session_ctx->generate_session_id) | ||
342 | cb = s->session_ctx->generate_session_id; | ||
343 | CRYPTO_r_unlock(CRYPTO_LOCK_SSL_CTX); | ||
344 | /* Choose a session ID */ | ||
345 | tmp = ss->session_id_length; | ||
346 | if (!cb(s, ss->session_id, &tmp)) { | ||
347 | /* The callback failed */ | ||
348 | SSLerr(SSL_F_SSL_GET_NEW_SESSION, | ||
349 | SSL_R_SSL_SESSION_ID_CALLBACK_FAILED); | ||
350 | SSL_SESSION_free(ss); | ||
351 | return (0); | ||
352 | } | ||
353 | /* Don't allow the callback to set the session length to zero. | ||
354 | * nor set it higher than it was. */ | ||
355 | if (!tmp || (tmp > ss->session_id_length)) { | ||
356 | /* The callback set an illegal length */ | ||
357 | SSLerr(SSL_F_SSL_GET_NEW_SESSION, | ||
358 | SSL_R_SSL_SESSION_ID_HAS_BAD_LENGTH); | ||
359 | SSL_SESSION_free(ss); | ||
360 | return (0); | ||
361 | } | ||
362 | /* If the session length was shrunk and we're SSLv2, pad it */ | ||
363 | if ((tmp < ss->session_id_length) && (s->version == SSL2_VERSION)) | ||
364 | memset(ss->session_id + tmp, 0, ss->session_id_length - tmp); | ||
365 | else | ||
366 | ss->session_id_length = tmp; | ||
367 | /* Finally, check for a conflict */ | ||
368 | if (SSL_has_matching_session_id(s, ss->session_id, | ||
369 | ss->session_id_length)) { | ||
370 | SSLerr(SSL_F_SSL_GET_NEW_SESSION, | ||
371 | SSL_R_SSL_SESSION_ID_CONFLICT); | ||
372 | SSL_SESSION_free(ss); | ||
373 | return (0); | ||
374 | } | ||
375 | #ifndef OPENSSL_NO_TLSEXT | ||
376 | sess_id_done: | ||
377 | if (s->tlsext_hostname) { | ||
378 | ss->tlsext_hostname = BUF_strdup(s->tlsext_hostname); | ||
379 | if (ss->tlsext_hostname == NULL) { | ||
380 | SSLerr(SSL_F_SSL_GET_NEW_SESSION, ERR_R_INTERNAL_ERROR); | ||
381 | SSL_SESSION_free(ss); | ||
382 | return 0; | ||
383 | } | ||
384 | } | ||
385 | #ifndef OPENSSL_NO_EC | ||
386 | if (s->tlsext_ecpointformatlist) { | ||
387 | if (ss->tlsext_ecpointformatlist != NULL) | ||
388 | OPENSSL_free(ss->tlsext_ecpointformatlist); | ||
389 | if ((ss->tlsext_ecpointformatlist = OPENSSL_malloc(s->tlsext_ecpointformatlist_length)) == NULL) { | ||
390 | SSLerr(SSL_F_SSL_GET_NEW_SESSION, ERR_R_MALLOC_FAILURE); | ||
391 | SSL_SESSION_free(ss); | ||
392 | return 0; | ||
393 | } | ||
394 | ss->tlsext_ecpointformatlist_length = s->tlsext_ecpointformatlist_length; | ||
395 | memcpy(ss->tlsext_ecpointformatlist, s->tlsext_ecpointformatlist, s->tlsext_ecpointformatlist_length); | ||
396 | } | ||
397 | if (s->tlsext_ellipticcurvelist) { | ||
398 | if (ss->tlsext_ellipticcurvelist != NULL) | ||
399 | OPENSSL_free(ss->tlsext_ellipticcurvelist); | ||
400 | if ((ss->tlsext_ellipticcurvelist = OPENSSL_malloc(s->tlsext_ellipticcurvelist_length)) == NULL) { | ||
401 | SSLerr(SSL_F_SSL_GET_NEW_SESSION, ERR_R_MALLOC_FAILURE); | ||
402 | SSL_SESSION_free(ss); | ||
403 | return 0; | ||
404 | } | ||
405 | ss->tlsext_ellipticcurvelist_length = s->tlsext_ellipticcurvelist_length; | ||
406 | memcpy(ss->tlsext_ellipticcurvelist, s->tlsext_ellipticcurvelist, s->tlsext_ellipticcurvelist_length); | ||
407 | } | ||
408 | #endif | ||
409 | #endif | ||
410 | } else { | ||
411 | ss->session_id_length = 0; | ||
412 | } | ||
413 | |||
414 | if (s->sid_ctx_length > sizeof ss->sid_ctx) { | ||
415 | SSLerr(SSL_F_SSL_GET_NEW_SESSION, ERR_R_INTERNAL_ERROR); | ||
416 | SSL_SESSION_free(ss); | ||
417 | return 0; | ||
418 | } | ||
419 | memcpy(ss->sid_ctx, s->sid_ctx, s->sid_ctx_length); | ||
420 | ss->sid_ctx_length = s->sid_ctx_length; | ||
421 | s->session = ss; | ||
422 | ss->ssl_version = s->version; | ||
423 | ss->verify_result = X509_V_OK; | ||
424 | |||
425 | return (1); | ||
426 | } | ||
427 | |||
428 | /* ssl_get_prev attempts to find an SSL_SESSION to be used to resume this | ||
429 | * connection. It is only called by servers. | ||
430 | * | ||
431 | * session_id: points at the session ID in the ClientHello. This code will | ||
432 | * read past the end of this in order to parse out the session ticket | ||
433 | * extension, if any. | ||
434 | * len: the length of the session ID. | ||
435 | * limit: a pointer to the first byte after the ClientHello. | ||
436 | * | ||
437 | * Returns: | ||
438 | * -1: error | ||
439 | * 0: a session may have been found. | ||
440 | * | ||
441 | * Side effects: | ||
442 | * - If a session is found then s->session is pointed at it (after freeing an | ||
443 | * existing session if need be) and s->verify_result is set from the session. | ||
444 | * - Both for new and resumed sessions, s->tlsext_ticket_expected is set to 1 | ||
445 | * if the server should issue a new session ticket (to 0 otherwise). | ||
446 | */ | ||
447 | int | ||
448 | ssl_get_prev_session(SSL *s, unsigned char *session_id, int len, | ||
449 | const unsigned char *limit) | ||
450 | { | ||
451 | /* This is used only by servers. */ | ||
452 | |||
453 | SSL_SESSION *ret = NULL; | ||
454 | int fatal = 0; | ||
455 | int try_session_cache = 1; | ||
456 | #ifndef OPENSSL_NO_TLSEXT | ||
457 | int r; | ||
458 | #endif | ||
459 | |||
460 | if (len > SSL_MAX_SSL_SESSION_ID_LENGTH) | ||
461 | goto err; | ||
462 | |||
463 | if (len == 0) | ||
464 | try_session_cache = 0; | ||
465 | |||
466 | #ifndef OPENSSL_NO_TLSEXT | ||
467 | r = tls1_process_ticket(s, session_id, len, limit, &ret); /* sets s->tlsext_ticket_expected */ | ||
468 | switch (r) { | ||
469 | case -1: /* Error during processing */ | ||
470 | fatal = 1; | ||
471 | goto err; | ||
472 | case 0: /* No ticket found */ | ||
473 | case 1: /* Zero length ticket found */ | ||
474 | break; /* Ok to carry on processing session id. */ | ||
475 | case 2: /* Ticket found but not decrypted. */ | ||
476 | case 3: /* Ticket decrypted, *ret has been set. */ | ||
477 | try_session_cache = 0; | ||
478 | break; | ||
479 | default: | ||
480 | abort(); | ||
481 | } | ||
482 | #endif | ||
483 | |||
484 | if (try_session_cache && | ||
485 | ret == NULL && | ||
486 | !(s->session_ctx->session_cache_mode & SSL_SESS_CACHE_NO_INTERNAL_LOOKUP)) { | ||
487 | SSL_SESSION data; | ||
488 | data.ssl_version = s->version; | ||
489 | data.session_id_length = len; | ||
490 | if (len == 0) | ||
491 | return 0; | ||
492 | memcpy(data.session_id, session_id, len); | ||
493 | CRYPTO_r_lock(CRYPTO_LOCK_SSL_CTX); | ||
494 | ret = lh_SSL_SESSION_retrieve(s->session_ctx->sessions, &data); | ||
495 | if (ret != NULL) { | ||
496 | /* don't allow other threads to steal it: */ | ||
497 | CRYPTO_add(&ret->references, 1, CRYPTO_LOCK_SSL_SESSION); | ||
498 | } | ||
499 | CRYPTO_r_unlock(CRYPTO_LOCK_SSL_CTX); | ||
500 | if (ret == NULL) | ||
501 | s->session_ctx->stats.sess_miss++; | ||
502 | } | ||
503 | |||
504 | if (try_session_cache && | ||
505 | ret == NULL && | ||
506 | s->session_ctx->get_session_cb != NULL) { | ||
507 | int copy = 1; | ||
508 | |||
509 | if ((ret = s->session_ctx->get_session_cb(s, session_id, len, ©))) { | ||
510 | s->session_ctx->stats.sess_cb_hit++; | ||
511 | |||
512 | /* Increment reference count now if the session callback | ||
513 | * asks us to do so (note that if the session structures | ||
514 | * returned by the callback are shared between threads, | ||
515 | * it must handle the reference count itself [i.e. copy == 0], | ||
516 | * or things won't be thread-safe). */ | ||
517 | if (copy) | ||
518 | CRYPTO_add(&ret->references, 1, CRYPTO_LOCK_SSL_SESSION); | ||
519 | |||
520 | /* Add the externally cached session to the internal | ||
521 | * cache as well if and only if we are supposed to. */ | ||
522 | if (!(s->session_ctx->session_cache_mode & SSL_SESS_CACHE_NO_INTERNAL_STORE)) | ||
523 | /* The following should not return 1, otherwise, | ||
524 | * things are very strange */ | ||
525 | SSL_CTX_add_session(s->session_ctx, ret); | ||
526 | } | ||
527 | } | ||
528 | |||
529 | if (ret == NULL) | ||
530 | goto err; | ||
531 | |||
532 | /* Now ret is non-NULL and we own one of its reference counts. */ | ||
533 | |||
534 | if (ret->sid_ctx_length != s->sid_ctx_length | ||
535 | || memcmp(ret->sid_ctx, s->sid_ctx, ret->sid_ctx_length)) { | ||
536 | /* We have the session requested by the client, but we don't | ||
537 | * want to use it in this context. */ | ||
538 | goto err; /* treat like cache miss */ | ||
539 | } | ||
540 | |||
541 | if ((s->verify_mode & SSL_VERIFY_PEER) && s->sid_ctx_length == 0) { | ||
542 | /* We can't be sure if this session is being used out of | ||
543 | * context, which is especially important for SSL_VERIFY_PEER. | ||
544 | * The application should have used SSL[_CTX]_set_session_id_context. | ||
545 | * | ||
546 | * For this error case, we generate an error instead of treating | ||
547 | * the event like a cache miss (otherwise it would be easy for | ||
548 | * applications to effectively disable the session cache by | ||
549 | * accident without anyone noticing). | ||
550 | */ | ||
551 | |||
552 | SSLerr(SSL_F_SSL_GET_PREV_SESSION, SSL_R_SESSION_ID_CONTEXT_UNINITIALIZED); | ||
553 | fatal = 1; | ||
554 | goto err; | ||
555 | } | ||
556 | |||
557 | if (ret->cipher == NULL) { | ||
558 | unsigned char buf[5], *p; | ||
559 | unsigned long l; | ||
560 | |||
561 | p = buf; | ||
562 | l = ret->cipher_id; | ||
563 | l2n(l, p); | ||
564 | if ((ret->ssl_version >> 8) >= SSL3_VERSION_MAJOR) | ||
565 | ret->cipher = ssl_get_cipher_by_char(s, &(buf[2])); | ||
566 | else | ||
567 | ret->cipher = ssl_get_cipher_by_char(s, &(buf[1])); | ||
568 | if (ret->cipher == NULL) | ||
569 | goto err; | ||
570 | } | ||
571 | |||
572 | if (ret->timeout < (long)(time(NULL) - ret->time)) /* timeout */ | ||
573 | { | ||
574 | s->session_ctx->stats.sess_timeout++; | ||
575 | if (try_session_cache) { | ||
576 | /* session was from the cache, so remove it */ | ||
577 | SSL_CTX_remove_session(s->session_ctx, ret); | ||
578 | } | ||
579 | goto err; | ||
580 | } | ||
581 | |||
582 | s->session_ctx->stats.sess_hit++; | ||
583 | |||
584 | if (s->session != NULL) | ||
585 | SSL_SESSION_free(s->session); | ||
586 | s->session = ret; | ||
587 | s->verify_result = s->session->verify_result; | ||
588 | return 1; | ||
589 | |||
590 | err: | ||
591 | if (ret != NULL) { | ||
592 | SSL_SESSION_free(ret); | ||
593 | #ifndef OPENSSL_NO_TLSEXT | ||
594 | if (!try_session_cache) { | ||
595 | /* The session was from a ticket, so we should | ||
596 | * issue a ticket for the new session */ | ||
597 | s->tlsext_ticket_expected = 1; | ||
598 | } | ||
599 | #endif | ||
600 | } | ||
601 | if (fatal) | ||
602 | return -1; | ||
603 | else | ||
604 | return 0; | ||
605 | } | ||
606 | |||
607 | int | ||
608 | SSL_CTX_add_session(SSL_CTX *ctx, SSL_SESSION *c) | ||
609 | { | ||
610 | int ret = 0; | ||
611 | SSL_SESSION *s; | ||
612 | |||
613 | /* add just 1 reference count for the SSL_CTX's session cache | ||
614 | * even though it has two ways of access: each session is in a | ||
615 | * doubly linked list and an lhash */ | ||
616 | CRYPTO_add(&c->references, 1, CRYPTO_LOCK_SSL_SESSION); | ||
617 | /* if session c is in already in cache, we take back the increment later */ | ||
618 | |||
619 | CRYPTO_w_lock(CRYPTO_LOCK_SSL_CTX); | ||
620 | s = lh_SSL_SESSION_insert(ctx->sessions, c); | ||
621 | |||
622 | /* s != NULL iff we already had a session with the given PID. | ||
623 | * In this case, s == c should hold (then we did not really modify | ||
624 | * ctx->sessions), or we're in trouble. */ | ||
625 | if (s != NULL && s != c) { | ||
626 | /* We *are* in trouble ... */ | ||
627 | SSL_SESSION_list_remove(ctx, s); | ||
628 | SSL_SESSION_free(s); | ||
629 | /* ... so pretend the other session did not exist in cache | ||
630 | * (we cannot handle two SSL_SESSION structures with identical | ||
631 | * session ID in the same cache, which could happen e.g. when | ||
632 | * two threads concurrently obtain the same session from an external | ||
633 | * cache) */ | ||
634 | s = NULL; | ||
635 | } | ||
636 | |||
637 | /* Put at the head of the queue unless it is already in the cache */ | ||
638 | if (s == NULL) | ||
639 | SSL_SESSION_list_add(ctx, c); | ||
640 | |||
641 | if (s != NULL) { | ||
642 | /* existing cache entry -- decrement previously incremented reference | ||
643 | * count because it already takes into account the cache */ | ||
644 | |||
645 | SSL_SESSION_free(s); /* s == c */ | ||
646 | ret = 0; | ||
647 | } else { | ||
648 | /* new cache entry -- remove old ones if cache has become too large */ | ||
649 | |||
650 | ret = 1; | ||
651 | |||
652 | if (SSL_CTX_sess_get_cache_size(ctx) > 0) { | ||
653 | while (SSL_CTX_sess_number(ctx) > | ||
654 | SSL_CTX_sess_get_cache_size(ctx)) { | ||
655 | if (!remove_session_lock(ctx, | ||
656 | ctx->session_cache_tail, 0)) | ||
657 | break; | ||
658 | else | ||
659 | ctx->stats.sess_cache_full++; | ||
660 | } | ||
661 | } | ||
662 | } | ||
663 | CRYPTO_w_unlock(CRYPTO_LOCK_SSL_CTX); | ||
664 | return (ret); | ||
665 | } | ||
666 | |||
667 | int | ||
668 | SSL_CTX_remove_session(SSL_CTX *ctx, SSL_SESSION *c) | ||
669 | { | ||
670 | return remove_session_lock(ctx, c, 1); | ||
671 | } | ||
672 | |||
673 | static int | ||
674 | remove_session_lock(SSL_CTX *ctx, SSL_SESSION *c, int lck) | ||
675 | { | ||
676 | SSL_SESSION *r; | ||
677 | int ret = 0; | ||
678 | |||
679 | if ((c != NULL) && (c->session_id_length != 0)) { | ||
680 | if (lck) | ||
681 | CRYPTO_w_lock(CRYPTO_LOCK_SSL_CTX); | ||
682 | if ((r = lh_SSL_SESSION_retrieve(ctx->sessions, c)) == c) { | ||
683 | ret = 1; | ||
684 | r = lh_SSL_SESSION_delete(ctx->sessions, c); | ||
685 | SSL_SESSION_list_remove(ctx, c); | ||
686 | } | ||
687 | |||
688 | if (lck) | ||
689 | CRYPTO_w_unlock(CRYPTO_LOCK_SSL_CTX); | ||
690 | |||
691 | if (ret) { | ||
692 | r->not_resumable = 1; | ||
693 | if (ctx->remove_session_cb != NULL) | ||
694 | ctx->remove_session_cb(ctx, r); | ||
695 | SSL_SESSION_free(r); | ||
696 | } | ||
697 | } else | ||
698 | ret = 0; | ||
699 | return (ret); | ||
700 | } | ||
701 | |||
702 | void | ||
703 | SSL_SESSION_free(SSL_SESSION *ss) | ||
704 | { | ||
705 | int i; | ||
706 | |||
707 | if (ss == NULL) | ||
708 | return; | ||
709 | |||
710 | i = CRYPTO_add(&ss->references, -1, CRYPTO_LOCK_SSL_SESSION); | ||
711 | #ifdef REF_PRINT | ||
712 | REF_PRINT("SSL_SESSION", ss); | ||
713 | #endif | ||
714 | if (i > 0) | ||
715 | return; | ||
716 | #ifdef REF_CHECK | ||
717 | if (i < 0) { | ||
718 | fprintf(stderr, "SSL_SESSION_free, bad reference count\n"); | ||
719 | abort(); /* ok */ | ||
720 | } | ||
721 | #endif | ||
722 | |||
723 | CRYPTO_free_ex_data(CRYPTO_EX_INDEX_SSL_SESSION, ss, &ss->ex_data); | ||
724 | |||
725 | OPENSSL_cleanse(ss->key_arg, sizeof ss->key_arg); | ||
726 | OPENSSL_cleanse(ss->master_key, sizeof ss->master_key); | ||
727 | OPENSSL_cleanse(ss->session_id, sizeof ss->session_id); | ||
728 | if (ss->sess_cert != NULL) | ||
729 | ssl_sess_cert_free(ss->sess_cert); | ||
730 | if (ss->peer != NULL) | ||
731 | X509_free(ss->peer); | ||
732 | if (ss->ciphers != NULL) | ||
733 | sk_SSL_CIPHER_free(ss->ciphers); | ||
734 | #ifndef OPENSSL_NO_TLSEXT | ||
735 | if (ss->tlsext_hostname != NULL) | ||
736 | OPENSSL_free(ss->tlsext_hostname); | ||
737 | if (ss->tlsext_tick != NULL) | ||
738 | OPENSSL_free(ss->tlsext_tick); | ||
739 | #ifndef OPENSSL_NO_EC | ||
740 | ss->tlsext_ecpointformatlist_length = 0; | ||
741 | if (ss->tlsext_ecpointformatlist != NULL) | ||
742 | OPENSSL_free(ss->tlsext_ecpointformatlist); | ||
743 | ss->tlsext_ellipticcurvelist_length = 0; | ||
744 | if (ss->tlsext_ellipticcurvelist != NULL) | ||
745 | OPENSSL_free(ss->tlsext_ellipticcurvelist); | ||
746 | #endif /* OPENSSL_NO_EC */ | ||
747 | #endif | ||
748 | #ifndef OPENSSL_NO_PSK | ||
749 | if (ss->psk_identity_hint != NULL) | ||
750 | OPENSSL_free(ss->psk_identity_hint); | ||
751 | if (ss->psk_identity != NULL) | ||
752 | OPENSSL_free(ss->psk_identity); | ||
753 | #endif | ||
754 | #ifndef OPENSSL_NO_SRP | ||
755 | if (ss->srp_username != NULL) | ||
756 | OPENSSL_free(ss->srp_username); | ||
757 | #endif | ||
758 | OPENSSL_cleanse(ss, sizeof(*ss)); | ||
759 | OPENSSL_free(ss); | ||
760 | } | ||
761 | |||
762 | int | ||
763 | SSL_set_session(SSL *s, SSL_SESSION *session) | ||
764 | { | ||
765 | int ret = 0; | ||
766 | const SSL_METHOD *meth; | ||
767 | |||
768 | if (session != NULL) { | ||
769 | meth = s->ctx->method->get_ssl_method(session->ssl_version); | ||
770 | if (meth == NULL) | ||
771 | meth = s->method->get_ssl_method(session->ssl_version); | ||
772 | if (meth == NULL) { | ||
773 | SSLerr(SSL_F_SSL_SET_SESSION, SSL_R_UNABLE_TO_FIND_SSL_METHOD); | ||
774 | return (0); | ||
775 | } | ||
776 | |||
777 | if (meth != s->method) { | ||
778 | if (!SSL_set_ssl_method(s, meth)) | ||
779 | return (0); | ||
780 | } | ||
781 | |||
782 | #ifndef OPENSSL_NO_KRB5 | ||
783 | if (s->kssl_ctx && !s->kssl_ctx->client_princ && | ||
784 | session->krb5_client_princ_len > 0) { | ||
785 | s->kssl_ctx->client_princ = (char *)OPENSSL_malloc(session->krb5_client_princ_len + 1); | ||
786 | memcpy(s->kssl_ctx->client_princ, session->krb5_client_princ, | ||
787 | session->krb5_client_princ_len); | ||
788 | s->kssl_ctx->client_princ[session->krb5_client_princ_len] = '\0'; | ||
789 | } | ||
790 | #endif /* OPENSSL_NO_KRB5 */ | ||
791 | |||
792 | /* CRYPTO_w_lock(CRYPTO_LOCK_SSL);*/ | ||
793 | CRYPTO_add(&session->references, 1, CRYPTO_LOCK_SSL_SESSION); | ||
794 | if (s->session != NULL) | ||
795 | SSL_SESSION_free(s->session); | ||
796 | s->session = session; | ||
797 | s->verify_result = s->session->verify_result; | ||
798 | /* CRYPTO_w_unlock(CRYPTO_LOCK_SSL);*/ | ||
799 | ret = 1; | ||
800 | } else { | ||
801 | if (s->session != NULL) { | ||
802 | SSL_SESSION_free(s->session); | ||
803 | s->session = NULL; | ||
804 | } | ||
805 | |||
806 | meth = s->ctx->method; | ||
807 | if (meth != s->method) { | ||
808 | if (!SSL_set_ssl_method(s, meth)) | ||
809 | return (0); | ||
810 | } | ||
811 | ret = 1; | ||
812 | } | ||
813 | return (ret); | ||
814 | } | ||
815 | |||
816 | long | ||
817 | SSL_SESSION_set_timeout(SSL_SESSION *s, long t) | ||
818 | { | ||
819 | if (s == NULL) | ||
820 | return (0); | ||
821 | s->timeout = t; | ||
822 | return (1); | ||
823 | } | ||
824 | |||
825 | long | ||
826 | SSL_SESSION_get_timeout(const SSL_SESSION *s) | ||
827 | { | ||
828 | if (s == NULL) | ||
829 | return (0); | ||
830 | return (s->timeout); | ||
831 | } | ||
832 | |||
833 | long | ||
834 | SSL_SESSION_get_time(const SSL_SESSION *s) | ||
835 | { | ||
836 | if (s == NULL) | ||
837 | return (0); | ||
838 | return (s->time); | ||
839 | } | ||
840 | |||
841 | long | ||
842 | SSL_SESSION_set_time(SSL_SESSION *s, long t) | ||
843 | { | ||
844 | if (s == NULL) | ||
845 | return (0); | ||
846 | s->time = t; | ||
847 | return (t); | ||
848 | } | ||
849 | |||
850 | X509 | ||
851 | *SSL_SESSION_get0_peer(SSL_SESSION *s) | ||
852 | { | ||
853 | return s->peer; | ||
854 | } | ||
855 | |||
856 | int | ||
857 | SSL_SESSION_set1_id_context(SSL_SESSION *s, const unsigned char *sid_ctx, | ||
858 | unsigned int sid_ctx_len) | ||
859 | { | ||
860 | if (sid_ctx_len > SSL_MAX_SID_CTX_LENGTH) { | ||
861 | SSLerr(SSL_F_SSL_SESSION_SET1_ID_CONTEXT, SSL_R_SSL_SESSION_ID_CONTEXT_TOO_LONG); | ||
862 | return 0; | ||
863 | } | ||
864 | s->sid_ctx_length = sid_ctx_len; | ||
865 | memcpy(s->sid_ctx, sid_ctx, sid_ctx_len); | ||
866 | |||
867 | return 1; | ||
868 | } | ||
869 | |||
870 | long | ||
871 | SSL_CTX_set_timeout(SSL_CTX *s, long t) | ||
872 | { | ||
873 | long l; | ||
874 | if (s == NULL) | ||
875 | return (0); | ||
876 | l = s->session_timeout; | ||
877 | s->session_timeout = t; | ||
878 | return (l); | ||
879 | } | ||
880 | |||
881 | long | ||
882 | SSL_CTX_get_timeout(const SSL_CTX *s) | ||
883 | { | ||
884 | if (s == NULL) | ||
885 | return (0); | ||
886 | return (s->session_timeout); | ||
887 | } | ||
888 | |||
889 | #ifndef OPENSSL_NO_TLSEXT | ||
890 | int | ||
891 | SSL_set_session_secret_cb(SSL *s, int (*tls_session_secret_cb)(SSL *s, void *secret, int *secret_len, | ||
892 | STACK_OF(SSL_CIPHER) *peer_ciphers, SSL_CIPHER **cipher, void *arg), void *arg) | ||
893 | { | ||
894 | if (s == NULL) | ||
895 | return (0); | ||
896 | s->tls_session_secret_cb = tls_session_secret_cb; | ||
897 | s->tls_session_secret_cb_arg = arg; | ||
898 | return (1); | ||
899 | } | ||
900 | |||
901 | int | ||
902 | SSL_set_session_ticket_ext_cb(SSL *s, tls_session_ticket_ext_cb_fn cb, | ||
903 | void *arg) | ||
904 | { | ||
905 | if (s == NULL) | ||
906 | return (0); | ||
907 | s->tls_session_ticket_ext_cb = cb; | ||
908 | s->tls_session_ticket_ext_cb_arg = arg; | ||
909 | return (1); | ||
910 | } | ||
911 | |||
912 | int | ||
913 | SSL_set_session_ticket_ext(SSL *s, void *ext_data, int ext_len) | ||
914 | { | ||
915 | if (s->version >= TLS1_VERSION) { | ||
916 | if (s->tlsext_session_ticket) { | ||
917 | OPENSSL_free(s->tlsext_session_ticket); | ||
918 | s->tlsext_session_ticket = NULL; | ||
919 | } | ||
920 | |||
921 | s->tlsext_session_ticket = OPENSSL_malloc(sizeof(TLS_SESSION_TICKET_EXT) + ext_len); | ||
922 | if (!s->tlsext_session_ticket) { | ||
923 | SSLerr(SSL_F_SSL_SET_SESSION_TICKET_EXT, ERR_R_MALLOC_FAILURE); | ||
924 | return 0; | ||
925 | } | ||
926 | |||
927 | if (ext_data) { | ||
928 | s->tlsext_session_ticket->length = ext_len; | ||
929 | s->tlsext_session_ticket->data = s->tlsext_session_ticket + 1; | ||
930 | memcpy(s->tlsext_session_ticket->data, ext_data, ext_len); | ||
931 | } else { | ||
932 | s->tlsext_session_ticket->length = 0; | ||
933 | s->tlsext_session_ticket->data = NULL; | ||
934 | } | ||
935 | |||
936 | return 1; | ||
937 | } | ||
938 | |||
939 | return 0; | ||
940 | } | ||
941 | #endif /* OPENSSL_NO_TLSEXT */ | ||
942 | |||
943 | typedef struct timeout_param_st { | ||
944 | SSL_CTX *ctx; | ||
945 | long time; | ||
946 | LHASH_OF(SSL_SESSION) *cache; | ||
947 | } TIMEOUT_PARAM; | ||
948 | |||
949 | static void | ||
950 | timeout_doall_arg(SSL_SESSION *s, TIMEOUT_PARAM *p) | ||
951 | { | ||
952 | if ((p->time == 0) || (p->time > (s->time+s->timeout))) /* timeout */ | ||
953 | { | ||
954 | /* The reason we don't call SSL_CTX_remove_session() is to | ||
955 | * save on locking overhead */ | ||
956 | (void)lh_SSL_SESSION_delete(p->cache, s); | ||
957 | SSL_SESSION_list_remove(p->ctx, s); | ||
958 | s->not_resumable = 1; | ||
959 | if (p->ctx->remove_session_cb != NULL) | ||
960 | p->ctx->remove_session_cb(p->ctx, s); | ||
961 | SSL_SESSION_free(s); | ||
962 | } | ||
963 | } | ||
964 | |||
965 | static | ||
966 | IMPLEMENT_LHASH_DOALL_ARG_FN(timeout, SSL_SESSION, TIMEOUT_PARAM) | ||
967 | |||
968 | void | ||
969 | SSL_CTX_flush_sessions(SSL_CTX *s, long t) | ||
970 | { | ||
971 | unsigned long i; | ||
972 | TIMEOUT_PARAM tp; | ||
973 | |||
974 | tp.ctx = s; | ||
975 | tp.cache = s->sessions; | ||
976 | if (tp.cache == NULL) | ||
977 | return; | ||
978 | tp.time = t; | ||
979 | CRYPTO_w_lock(CRYPTO_LOCK_SSL_CTX); | ||
980 | i = CHECKED_LHASH_OF(SSL_SESSION, tp.cache)->down_load; | ||
981 | CHECKED_LHASH_OF(SSL_SESSION, tp.cache)->down_load = 0; | ||
982 | lh_SSL_SESSION_doall_arg(tp.cache, LHASH_DOALL_ARG_FN(timeout), | ||
983 | TIMEOUT_PARAM, &tp); | ||
984 | CHECKED_LHASH_OF(SSL_SESSION, tp.cache)->down_load = i; | ||
985 | CRYPTO_w_unlock(CRYPTO_LOCK_SSL_CTX); | ||
986 | } | ||
987 | |||
988 | int | ||
989 | ssl_clear_bad_session(SSL *s) | ||
990 | { | ||
991 | if ((s->session != NULL) && | ||
992 | !(s->shutdown & SSL_SENT_SHUTDOWN) && | ||
993 | !(SSL_in_init(s) || SSL_in_before(s))) { | ||
994 | SSL_CTX_remove_session(s->ctx, s->session); | ||
995 | return (1); | ||
996 | } else | ||
997 | return (0); | ||
998 | } | ||
999 | |||
1000 | /* locked by SSL_CTX in the calling function */ | ||
1001 | static void | ||
1002 | SSL_SESSION_list_remove(SSL_CTX *ctx, SSL_SESSION *s) | ||
1003 | { | ||
1004 | if ((s->next == NULL) | ||
1005 | || (s->prev == NULL)) return; | ||
1006 | |||
1007 | if (s->next == (SSL_SESSION *)&(ctx->session_cache_tail)) | ||
1008 | { /* last element in list */ | ||
1009 | if (s->prev == (SSL_SESSION *)&(ctx->session_cache_head)) | ||
1010 | { /* only one element in list */ | ||
1011 | ctx->session_cache_head = NULL; | ||
1012 | ctx->session_cache_tail = NULL; | ||
1013 | } else { | ||
1014 | ctx->session_cache_tail = s->prev; | ||
1015 | s->prev->next = (SSL_SESSION *)&(ctx->session_cache_tail); | ||
1016 | } | ||
1017 | } else { | ||
1018 | if (s->prev == (SSL_SESSION *)&(ctx->session_cache_head)) | ||
1019 | { /* first element in list */ | ||
1020 | ctx->session_cache_head = s->next; | ||
1021 | s->next->prev = (SSL_SESSION *)&(ctx->session_cache_head); | ||
1022 | } else | ||
1023 | { /* middle of list */ | ||
1024 | s->next->prev = s->prev; | ||
1025 | s->prev->next = s->next; | ||
1026 | } | ||
1027 | } | ||
1028 | s->prev = s->next = NULL; | ||
1029 | } | ||
1030 | |||
1031 | static void | ||
1032 | SSL_SESSION_list_add(SSL_CTX *ctx, SSL_SESSION *s) | ||
1033 | { | ||
1034 | if ((s->next != NULL) && (s->prev != NULL)) | ||
1035 | SSL_SESSION_list_remove(ctx, s); | ||
1036 | |||
1037 | if (ctx->session_cache_head == NULL) { | ||
1038 | ctx->session_cache_head = s; | ||
1039 | ctx->session_cache_tail = s; | ||
1040 | s->prev = (SSL_SESSION *)&(ctx->session_cache_head); | ||
1041 | s->next = (SSL_SESSION *)&(ctx->session_cache_tail); | ||
1042 | } else { | ||
1043 | s->next = ctx->session_cache_head; | ||
1044 | s->next->prev = s; | ||
1045 | s->prev = (SSL_SESSION *)&(ctx->session_cache_head); | ||
1046 | ctx->session_cache_head = s; | ||
1047 | } | ||
1048 | } | ||
1049 | |||
1050 | void | ||
1051 | SSL_CTX_sess_set_new_cb(SSL_CTX *ctx, | ||
1052 | int (*cb)(struct ssl_st *ssl, SSL_SESSION *sess)) { | ||
1053 | ctx->new_session_cb = cb; | ||
1054 | } | ||
1055 | |||
1056 | int (*SSL_CTX_sess_get_new_cb(SSL_CTX *ctx))(SSL *ssl, SSL_SESSION *sess) | ||
1057 | { | ||
1058 | return ctx->new_session_cb; | ||
1059 | } | ||
1060 | |||
1061 | void | ||
1062 | SSL_CTX_sess_set_remove_cb(SSL_CTX *ctx, | ||
1063 | void (*cb)(SSL_CTX *ctx, SSL_SESSION *sess)) | ||
1064 | { | ||
1065 | ctx->remove_session_cb = cb; | ||
1066 | } | ||
1067 | |||
1068 | void (*SSL_CTX_sess_get_remove_cb(SSL_CTX *ctx))(SSL_CTX * ctx, SSL_SESSION *sess) | ||
1069 | { | ||
1070 | return ctx->remove_session_cb; | ||
1071 | } | ||
1072 | |||
1073 | void | ||
1074 | SSL_CTX_sess_set_get_cb(SSL_CTX *ctx, | ||
1075 | SSL_SESSION *(*cb)(struct ssl_st *ssl, | ||
1076 | unsigned char *data, int len, int *copy)) | ||
1077 | { | ||
1078 | ctx->get_session_cb = cb; | ||
1079 | } | ||
1080 | |||
1081 | SSL_SESSION * (*SSL_CTX_sess_get_get_cb(SSL_CTX *ctx))(SSL *ssl, | ||
1082 | unsigned char *data, int len, int *copy) | ||
1083 | { | ||
1084 | return ctx->get_session_cb; | ||
1085 | } | ||
1086 | |||
1087 | void | ||
1088 | SSL_CTX_set_info_callback(SSL_CTX *ctx, | ||
1089 | void (*cb)(const SSL *ssl, int type, int val)) | ||
1090 | { | ||
1091 | ctx->info_callback = cb; | ||
1092 | } | ||
1093 | |||
1094 | void (*SSL_CTX_get_info_callback(SSL_CTX *ctx))(const SSL *ssl, int type, int val) | ||
1095 | { | ||
1096 | return ctx->info_callback; | ||
1097 | } | ||
1098 | |||
1099 | void | ||
1100 | SSL_CTX_set_client_cert_cb(SSL_CTX *ctx, | ||
1101 | int (*cb)(SSL *ssl, X509 **x509, EVP_PKEY **pkey)) | ||
1102 | { | ||
1103 | ctx->client_cert_cb = cb; | ||
1104 | } | ||
1105 | |||
1106 | int (*SSL_CTX_get_client_cert_cb(SSL_CTX *ctx))(SSL * ssl, X509 ** x509 , EVP_PKEY **pkey) | ||
1107 | { | ||
1108 | return ctx->client_cert_cb; | ||
1109 | } | ||
1110 | |||
1111 | #ifndef OPENSSL_NO_ENGINE | ||
1112 | int | ||
1113 | SSL_CTX_set_client_cert_engine(SSL_CTX *ctx, ENGINE *e) | ||
1114 | { | ||
1115 | if (!ENGINE_init(e)) { | ||
1116 | SSLerr(SSL_F_SSL_CTX_SET_CLIENT_CERT_ENGINE, ERR_R_ENGINE_LIB); | ||
1117 | return 0; | ||
1118 | } | ||
1119 | if (!ENGINE_get_ssl_client_cert_function(e)) { | ||
1120 | SSLerr(SSL_F_SSL_CTX_SET_CLIENT_CERT_ENGINE, SSL_R_NO_CLIENT_CERT_METHOD); | ||
1121 | ENGINE_finish(e); | ||
1122 | return 0; | ||
1123 | } | ||
1124 | ctx->client_cert_engine = e; | ||
1125 | return 1; | ||
1126 | } | ||
1127 | #endif | ||
1128 | |||
1129 | void | ||
1130 | SSL_CTX_set_cookie_generate_cb(SSL_CTX *ctx, | ||
1131 | int (*cb)(SSL *ssl, unsigned char *cookie, unsigned int *cookie_len)) | ||
1132 | { | ||
1133 | ctx->app_gen_cookie_cb = cb; | ||
1134 | } | ||
1135 | |||
1136 | void | ||
1137 | SSL_CTX_set_cookie_verify_cb(SSL_CTX *ctx, | ||
1138 | int (*cb)(SSL *ssl, unsigned char *cookie, unsigned int cookie_len)) | ||
1139 | { | ||
1140 | ctx->app_verify_cookie_cb = cb; | ||
1141 | } | ||
1142 | |||
1143 | IMPLEMENT_PEM_rw(SSL_SESSION, SSL_SESSION, PEM_STRING_SSL_SESSION, SSL_SESSION) | ||