ssl_sess.c 20.7 KB
Newer Older
1
/* ssl/ssl_sess.c */
2
/* Copyright (C) 1995-1998 Eric Young (eay@cryptsoft.com)
3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59
 * All rights reserved.
 *
 * This package is an SSL implementation written
 * by Eric Young (eay@cryptsoft.com).
 * The implementation was written so as to conform with Netscapes SSL.
 * 
 * This library is free for commercial and non-commercial use as long as
 * the following conditions are aheared to.  The following conditions
 * apply to all code found in this distribution, be it the RC4, RSA,
 * lhash, DES, etc., code; not just the SSL code.  The SSL documentation
 * included with this distribution is covered by the same copyright terms
 * except that the holder is Tim Hudson (tjh@cryptsoft.com).
 * 
 * Copyright remains Eric Young's, and as such any Copyright notices in
 * the code are not to be removed.
 * If this package is used in a product, Eric Young should be given attribution
 * as the author of the parts of the library used.
 * This can be in the form of a textual message at program startup or
 * in documentation (online or textual) provided with the package.
 * 
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions
 * are met:
 * 1. Redistributions of source code must retain the copyright
 *    notice, this list of conditions and the following disclaimer.
 * 2. Redistributions in binary form must reproduce the above copyright
 *    notice, this list of conditions and the following disclaimer in the
 *    documentation and/or other materials provided with the distribution.
 * 3. All advertising materials mentioning features or use of this software
 *    must display the following acknowledgement:
 *    "This product includes cryptographic software written by
 *     Eric Young (eay@cryptsoft.com)"
 *    The word 'cryptographic' can be left out if the rouines from the library
 *    being used are not cryptographic related :-).
 * 4. If you include any Windows specific code (or a derivative thereof) from 
 *    the apps directory (application code) you must include an acknowledgement:
 *    "This product includes software written by Tim Hudson (tjh@cryptsoft.com)"
 * 
 * THIS SOFTWARE IS PROVIDED BY ERIC YOUNG ``AS IS'' AND
 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
 * ARE DISCLAIMED.  IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
 * SUCH DAMAGE.
 * 
 * The licence and distribution terms for any publically available version or
 * derivative of this code cannot be changed.  i.e. this code cannot simply be
 * copied and put under another distribution licence
 * [including the GNU Public Licence.]
 */

#include <stdio.h>
60 61
#include <openssl/lhash.h>
#include <openssl/rand.h>
62
#include "ssl_locl.h"
63
#include "cryptlib.h"
64

65 66
static void SSL_SESSION_list_remove(SSL_CTX *ctx, SSL_SESSION *s);
static void SSL_SESSION_list_add(SSL_CTX *ctx,SSL_SESSION *s);
67
static int remove_session_lock(SSL_CTX *ctx, SSL_SESSION *c, int lck);
68

69
SSL_SESSION *SSL_get_session(SSL *ssl)
70
/* aka SSL_get0_session; gets 0 objects, just returns a copy of the pointer */
71 72 73
	{
	return(ssl->session);
	}
74 75 76

SSL_SESSION *SSL_get1_session(SSL *ssl)
/* variant of SSL_get_session: caller really gets something */
77
	{
78 79 80 81 82 83 84 85 86 87
	SSL_SESSION *sess;
	/* Need to lock this all up rather than just use CRYPTO_add so that
	 * somebody doesn't free ssl->session between when we check it's
	 * non-null and when we up the reference count. */
	CRYPTO_r_lock(CRYPTO_LOCK_SSL_SESSION);
	sess = ssl->session;
	if(sess)
		sess->references++;
	CRYPTO_r_unlock(CRYPTO_LOCK_SSL_SESSION);
	return(sess);
88 89
	}

D
 
Dr. Stephen Henson 已提交
90 91
int SSL_SESSION_get_ex_new_index(long argl, void *argp, CRYPTO_EX_new *new_func,
	     CRYPTO_EX_dup *dup_func, CRYPTO_EX_free *free_func)
92
	{
93 94
	return CRYPTO_get_ex_new_index(CRYPTO_EX_INDEX_SSL_SESSION, argl, argp,
			new_func, dup_func, free_func);
95
	}
96

U
Ulf Möller 已提交
97
int SSL_SESSION_set_ex_data(SSL_SESSION *s, int idx, void *arg)
98 99 100 101
	{
	return(CRYPTO_set_ex_data(&s->ex_data,idx,arg));
	}

U
Ulf Möller 已提交
102
void *SSL_SESSION_get_ex_data(SSL_SESSION *s, int idx)
103 104 105 106
	{
	return(CRYPTO_get_ex_data(&s->ex_data,idx));
	}

U
Ulf Möller 已提交
107
SSL_SESSION *SSL_SESSION_new(void)
108 109 110
	{
	SSL_SESSION *ss;

111
	ss=(SSL_SESSION *)OPENSSL_malloc(sizeof(SSL_SESSION));
112 113 114 115 116 117 118
	if (ss == NULL)
		{
		SSLerr(SSL_F_SSL_SESSION_NEW,ERR_R_MALLOC_FAILURE);
		return(0);
		}
	memset(ss,0,sizeof(SSL_SESSION));

119
	ss->verify_result = 1; /* avoid 0 (= X509_V_OK) just in case */
120 121 122
	ss->references=1;
	ss->timeout=60*5+4; /* 5 minute timeout by default */
	ss->time=time(NULL);
123 124
	ss->prev=NULL;
	ss->next=NULL;
125
	ss->compress_meth=0;
126
	CRYPTO_new_ex_data(CRYPTO_EX_INDEX_SSL_SESSION, ss, &ss->ex_data);
127 128 129
	return(ss);
	}

130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145
/* Even with SSLv2, we have 16 bytes (128 bits) of session ID space. SSLv3/TLSv1
 * has 32 bytes (256 bits). As such, filling the ID with random gunk repeatedly
 * until we have no conflict is going to complete in one iteration pretty much
 * "most" of the time (btw: understatement). So, if it takes us 10 iterations
 * and we still can't avoid a conflict - well that's a reasonable point to call
 * it quits. Either the RAND code is broken or someone is trying to open roughly
 * very close to 2^128 (or 2^256) SSL sessions to our server. How you might
 * store that many sessions is perhaps a more interesting question ... */

#define MAX_SESS_ID_ATTEMPTS 10
static int def_generate_session_id(const SSL *ssl, unsigned char *id,
				unsigned int *id_len)
{
	unsigned int retry = 0;
	do
		RAND_pseudo_bytes(id, *id_len);
146
	while(SSL_has_matching_session_id(ssl, id, *id_len) &&
147 148 149 150 151 152 153 154 155 156 157 158 159 160 161
		(++retry < MAX_SESS_ID_ATTEMPTS));
	if(retry < MAX_SESS_ID_ATTEMPTS)
		return 1;
	/* else - woops a session_id match */
	/* XXX We should also check the external cache --
	 * but the probability of a collision is negligible, and
	 * we could not prevent the concurrent creation of sessions
	 * with identical IDs since we currently don't have means
	 * to atomically check whether a session ID already exists
	 * and make a reservation for it if it does not
	 * (this problem applies to the internal cache as well).
	 */
	return 0;
}

U
Ulf Möller 已提交
162
int ssl_get_new_session(SSL *s, int session)
163
	{
164 165
	/* This gets used by clients and servers. */

166
	unsigned int tmp;
167
	SSL_SESSION *ss=NULL;
168
	GEN_SESSION_CB cb = def_generate_session_id;
169 170 171 172

	if ((ss=SSL_SESSION_new()) == NULL) return(0);

	/* If the context has a default timeout, use it */
173
	if (s->ctx->session_timeout == 0)
174
		ss->timeout=SSL_get_default_timeout(s);
175 176
	else
		ss->timeout=s->ctx->session_timeout;
177 178 179 180 181 182 183 184 185

	if (s->session != NULL)
		{
		SSL_SESSION_free(s->session);
		s->session=NULL;
		}

	if (session)
		{
186
		if (s->version == SSL2_VERSION)
187
			{
188
			ss->ssl_version=SSL2_VERSION;
189 190
			ss->session_id_length=SSL2_SSL_SESSION_ID_LENGTH;
			}
191
		else if (s->version == SSL3_VERSION)
192
			{
193 194 195 196 197 198
			ss->ssl_version=SSL3_VERSION;
			ss->session_id_length=SSL3_SSL_SESSION_ID_LENGTH;
			}
		else if (s->version == TLS1_VERSION)
			{
			ss->ssl_version=TLS1_VERSION;
199 200 201 202 203 204 205 206
			ss->session_id_length=SSL3_SSL_SESSION_ID_LENGTH;
			}
		else
			{
			SSLerr(SSL_F_SSL_GET_NEW_SESSION,SSL_R_UNSUPPORTED_SSL_VERSION);
			SSL_SESSION_free(ss);
			return(0);
			}
207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226
		/* Choose which callback will set the session ID */
		CRYPTO_r_lock(CRYPTO_LOCK_SSL_CTX);
		if(s->generate_session_id)
			cb = s->generate_session_id;
		else if(s->ctx->generate_session_id)
			cb = s->ctx->generate_session_id;
		CRYPTO_r_unlock(CRYPTO_LOCK_SSL_CTX);
		/* Choose a session ID */
		tmp = ss->session_id_length;
		if(!cb(s, ss->session_id, &tmp))
			{
			/* The callback failed */
			SSLerr(SSL_F_SSL_GET_NEW_SESSION,
				SSL_R_SSL_SESSION_ID_CALLBACK_FAILED);
			SSL_SESSION_free(ss);
			return(0);
			}
		/* Don't allow the callback to set the session length to zero.
		 * nor set it higher than it was. */
		if(!tmp || (tmp > ss->session_id_length))
227
			{
228 229 230 231 232 233 234 235 236 237 238 239
			/* The callback set an illegal length */
			SSLerr(SSL_F_SSL_GET_NEW_SESSION,
				SSL_R_SSL_SESSION_ID_HAS_BAD_LENGTH);
			SSL_SESSION_free(ss);
			return(0);
			}
		/* If the session length was shrunk and we're SSLv2, pad it */
		if((tmp < ss->session_id_length) && (s->version == SSL2_VERSION))
			memset(ss->session_id + tmp, 0, ss->session_id_length - tmp);
		else
			ss->session_id_length = tmp;
		/* Finally, check for a conflict */
240
		if(SSL_has_matching_session_id(s, ss->session_id,
241 242 243 244 245 246
						ss->session_id_length))
			{
			SSLerr(SSL_F_SSL_GET_NEW_SESSION,
				SSL_R_SSL_SESSION_ID_CONFLICT);
			SSL_SESSION_free(ss);
			return(0);
247 248 249 250 251 252 253
			}
		}
	else
		{
		ss->session_id_length=0;
		}

254
	die(s->sid_ctx_length <= sizeof ss->sid_ctx);
B
Ben Laurie 已提交
255 256
	memcpy(ss->sid_ctx,s->sid_ctx,s->sid_ctx_length);
	ss->sid_ctx_length=s->sid_ctx_length;
257 258
	s->session=ss;
	ss->ssl_version=s->version;
259
	ss->verify_result = X509_V_OK;
260 261 262 263

	return(1);
	}

U
Ulf Möller 已提交
264
int ssl_get_prev_session(SSL *s, unsigned char *session_id, int len)
265
	{
266 267
	/* This is used only by servers. */

268
	SSL_SESSION *ret=NULL,data;
269
	int fatal = 0;
270 271 272 273

	data.ssl_version=s->version;
	data.session_id_length=len;
	if (len > SSL_MAX_SSL_SESSION_ID_LENGTH)
274
		goto err;
B
Ben Laurie 已提交
275
	memcpy(data.session_id,session_id,len);
276

277 278 279
	if (!(s->ctx->session_cache_mode & SSL_SESS_CACHE_NO_INTERNAL_LOOKUP))
		{
		CRYPTO_r_lock(CRYPTO_LOCK_SSL_CTX);
280
		ret=(SSL_SESSION *)lh_retrieve(s->ctx->sessions,&data);
B
Bodo Möller 已提交
281 282 283
		if (ret != NULL)
		    /* don't allow other threads to steal it: */
		    CRYPTO_add(&ret->references,1,CRYPTO_LOCK_SSL_SESSION);
284 285
		CRYPTO_r_unlock(CRYPTO_LOCK_SSL_CTX);
		}
286 287 288

	if (ret == NULL)
		{
289 290
		int copy=1;
	
291
		s->ctx->stats.sess_miss++;
292
		ret=NULL;
B
Ben Laurie 已提交
293 294 295
		if (s->ctx->get_session_cb != NULL
		    && (ret=s->ctx->get_session_cb(s,session_id,len,&copy))
		       != NULL)
296
			{
297
			s->ctx->stats.sess_cb_hit++;
298

299 300 301 302 303 304 305 306
			/* Increment reference count now if the session callback
			 * asks us to do so (note that if the session structures
			 * returned by the callback are shared between threads,
			 * it must handle the reference count itself [i.e. copy == 0],
			 * or things won't be thread-safe). */
			if (copy)
				CRYPTO_add(&ret->references,1,CRYPTO_LOCK_SSL_SESSION);

307 308 309 310
			/* The following should not return 1, otherwise,
			 * things are very strange */
			SSL_CTX_add_session(s->ctx,ret);
			}
311 312
		if (ret == NULL)
			goto err;
313 314
		}

315 316
	/* Now ret is non-NULL, and we own one of its reference counts. */

B
Ben Laurie 已提交
317 318 319 320
	if((s->verify_mode&SSL_VERIFY_PEER)
	   && (!s->sid_ctx_length || ret->sid_ctx_length != s->sid_ctx_length
	       || memcmp(ret->sid_ctx,s->sid_ctx,ret->sid_ctx_length)))
	    {
321 322 323 324 325 326 327 328 329 330
		/* We've found the session named by the client, but we don't
		 * want to use it in this context. */
		
		if (s->sid_ctx_length == 0)
			{
			/* application should have used SSL[_CTX]_set_session_id_context
			 * -- we could tolerate this and just pretend we never heard
			 * of this session, but then applications could effectively
			 * disable the session cache by accident without anyone noticing */

331
			SSLerr(SSL_F_SSL_GET_PREV_SESSION,SSL_R_SESSION_ID_CONTEXT_UNINITIALIZED);
332 333 334 335 336 337 338 339 340 341 342 343 344
			fatal = 1;
			goto err;
			}
		else
			{
#if 0 /* The client cannot always know when a session is not appropriate,
	   * so we shouldn't generate an error message. */

			SSLerr(SSL_F_SSL_GET_PREV_SESSION,SSL_R_ATTEMPT_TO_REUSE_SESSION_IN_DIFFERENT_CONTEXT);
#endif
			goto err; /* treat like cache miss */
			}
		}
B
Ben Laurie 已提交
345

346 347
	if (ret->cipher == NULL)
		{
348
		unsigned char buf[5],*p;
349 350 351 352 353
		unsigned long l;

		p=buf;
		l=ret->cipher_id;
		l2n(l,p);
354
		if ((ret->ssl_version>>8) == SSL3_VERSION_MAJOR)
355 356 357 358
			ret->cipher=ssl_get_cipher_by_char(s,&(buf[2]));
		else 
			ret->cipher=ssl_get_cipher_by_char(s,&(buf[1]));
		if (ret->cipher == NULL)
359
			goto err;
360 361
		}

362 363 364

#if 0 /* This is way too late. */

365
	/* If a thread got the session, then 'swaped', and another got
366
	 * it and then due to a time-out decided to 'OPENSSL_free' it we could
367 368 369
	 * be in trouble.  So I'll increment it now, then double decrement
	 * later - am I speaking rubbish?. */
	CRYPTO_add(&ret->references,1,CRYPTO_LOCK_SSL_SESSION);
370
#endif
371 372 373

	if ((long)(ret->time+ret->timeout) < (long)time(NULL)) /* timeout */
		{
374
		s->ctx->stats.sess_timeout++;
375 376
		/* remove it from the cache */
		SSL_CTX_remove_session(s->ctx,ret);
377
		goto err;
378 379
		}

380
	s->ctx->stats.sess_hit++;
381 382 383 384 385 386 387 388

	/* ret->time=time(NULL); */ /* rezero timeout? */
	/* again, just leave the session 
	 * if it is the same session, we have just incremented and
	 * then decremented the reference count :-) */
	if (s->session != NULL)
		SSL_SESSION_free(s->session);
	s->session=ret;
389
	s->verify_result = s->session->verify_result;
390
	return(1);
391 392 393 394 395 396 397 398

 err:
	if (ret != NULL)
		SSL_SESSION_free(ret);
	if (fatal)
		return -1;
	else
		return 0;
399 400
	}

U
Ulf Möller 已提交
401
int SSL_CTX_add_session(SSL_CTX *ctx, SSL_SESSION *c)
402
	{
403
	int ret=0;
404 405
	SSL_SESSION *s;

406 407 408
	/* add just 1 reference count for the SSL_CTX's session cache
	 * even though it has two ways of access: each session is in a
	 * doubly linked list and an lhash */
409
	CRYPTO_add(&c->references,1,CRYPTO_LOCK_SSL_SESSION);
410
	/* if session c is in already in cache, we take back the increment later */
411 412

	CRYPTO_w_lock(CRYPTO_LOCK_SSL_CTX);
413
	s=(SSL_SESSION *)lh_insert(ctx->sessions,c);
414
	
415 416 417 418 419 420 421 422 423 424 425 426 427 428 429 430 431
	/* s != NULL iff we already had a session with the given PID.
	 * In this case, s == c should hold (then we did not really modify
	 * ctx->sessions), or we're in trouble. */
	if (s != NULL && s != c)
		{
		/* We *are* in trouble ... */
		SSL_SESSION_list_remove(ctx,s);
		SSL_SESSION_free(s);
		/* ... so pretend the other session did not exist in cache
		 * (we cannot handle two SSL_SESSION structures with identical
		 * session ID in the same cache, which could happen e.g. when
		 * two threads concurrently obtain the same session from an external
		 * cache) */
		s = NULL;
		}

 	/* Put at the head of the queue unless it is already in the cache */
432 433
	if (s == NULL)
		SSL_SESSION_list_add(ctx,c);
434 435 436

	if (s != NULL)
		{
437 438 439 440
		/* existing cache entry -- decrement previously incremented reference
		 * count because it already takes into account the cache */

		SSL_SESSION_free(s); /* s == c */
441
		ret=0;
442 443
		}
	else
444
		{
445 446
		/* new cache entry -- remove old ones if cache has become too large */
		
447 448 449 450 451 452 453
		ret=1;

		if (SSL_CTX_sess_get_cache_size(ctx) > 0)
			{
			while (SSL_CTX_sess_number(ctx) >
				SSL_CTX_sess_get_cache_size(ctx))
				{
454 455
				if (!remove_session_lock(ctx,
					ctx->session_cache_tail, 0))
456 457
					break;
				else
458
					ctx->stats.sess_cache_full++;
459 460 461 462 463
				}
			}
		}
	CRYPTO_w_unlock(CRYPTO_LOCK_SSL_CTX);
	return(ret);
464 465
	}

U
Ulf Möller 已提交
466
int SSL_CTX_remove_session(SSL_CTX *ctx, SSL_SESSION *c)
467 468 469 470
{
	return remove_session_lock(ctx, c, 1);
}

471
static int remove_session_lock(SSL_CTX *ctx, SSL_SESSION *c, int lck)
472 473 474 475
	{
	SSL_SESSION *r;
	int ret=0;

476
	if ((c != NULL) && (c->session_id_length != 0))
477
		{
478
		if(lck) CRYPTO_w_lock(CRYPTO_LOCK_SSL_CTX);
479
		if ((r = (SSL_SESSION *)lh_retrieve(ctx->sessions,c)) == c)
480 481
			{
			ret=1;
482
			r=(SSL_SESSION *)lh_delete(ctx->sessions,c);
483 484
			SSL_SESSION_list_remove(ctx,c);
			}
485

486
		if(lck) CRYPTO_w_unlock(CRYPTO_LOCK_SSL_CTX);
487 488 489 490 491

		if (ret)
			{
			r->not_resumable=1;
			if (ctx->remove_session_cb != NULL)
492
				ctx->remove_session_cb(ctx,r);
493 494 495 496 497 498 499 500
			SSL_SESSION_free(r);
			}
		}
	else
		ret=0;
	return(ret);
	}

U
Ulf Möller 已提交
501
void SSL_SESSION_free(SSL_SESSION *ss)
502 503 504
	{
	int i;

B
Ben Laurie 已提交
505 506 507
	if(ss == NULL)
	    return;

508
	i=CRYPTO_add(&ss->references,-1,CRYPTO_LOCK_SSL_SESSION);
509 510 511
#ifdef REF_PRINT
	REF_PRINT("SSL_SESSION",ss);
#endif
512 513 514 515 516 517 518 519 520
	if (i > 0) return;
#ifdef REF_CHECK
	if (i < 0)
		{
		fprintf(stderr,"SSL_SESSION_free, bad reference count\n");
		abort(); /* ok */
		}
#endif

521
	CRYPTO_free_ex_data(CRYPTO_EX_INDEX_SSL_SESSION, ss, &ss->ex_data);
522

523 524 525
	memset(ss->key_arg,0,SSL_MAX_KEY_ARG_LENGTH);
	memset(ss->master_key,0,SSL_MAX_MASTER_KEY_LENGTH);
	memset(ss->session_id,0,SSL_MAX_SSL_SESSION_ID_LENGTH);
526
	if (ss->sess_cert != NULL) ssl_sess_cert_free(ss->sess_cert);
527
	if (ss->peer != NULL) X509_free(ss->peer);
B
Ben Laurie 已提交
528
	if (ss->ciphers != NULL) sk_SSL_CIPHER_free(ss->ciphers);
529
	memset(ss,0,sizeof(*ss));
530
	OPENSSL_free(ss);
531 532
	}

U
Ulf Möller 已提交
533
int SSL_set_session(SSL *s, SSL_SESSION *session)
534 535 536 537 538 539 540 541 542 543 544 545 546 547 548 549 550 551 552
	{
	int ret=0;
	SSL_METHOD *meth;

	if (session != NULL)
		{
		meth=s->ctx->method->get_ssl_method(session->ssl_version);
		if (meth == NULL)
			meth=s->method->get_ssl_method(session->ssl_version);
		if (meth == NULL)
			{
			SSLerr(SSL_F_SSL_SET_SESSION,SSL_R_UNABLE_TO_FIND_SSL_METHOD);
			return(0);
			}

		if (meth != s->method)
			{
			if (!SSL_set_ssl_method(s,meth))
				return(0);
553 554 555 556
			if (s->ctx->session_timeout == 0)
				session->timeout=SSL_get_default_timeout(s);
			else
				session->timeout=s->ctx->session_timeout;
557 558
			}

559 560 561 562 563 564 565
#ifndef OPENSSL_NO_KRB5
                if (s->kssl_ctx && !s->kssl_ctx->client_princ &&
                    session->krb5_client_princ_len > 0)
                {
                    s->kssl_ctx->client_princ = (char *)malloc(session->krb5_client_princ_len + 1);
                    memcpy(s->kssl_ctx->client_princ,session->krb5_client_princ,
                            session->krb5_client_princ_len);
566
                    s->kssl_ctx->client_princ[session->krb5_client_princ_len] = '\0';
567 568 569
                }
#endif /* OPENSSL_NO_KRB5 */

570 571 572 573 574
		/* CRYPTO_w_lock(CRYPTO_LOCK_SSL);*/
		CRYPTO_add(&session->references,1,CRYPTO_LOCK_SSL_SESSION);
		if (s->session != NULL)
			SSL_SESSION_free(s->session);
		s->session=session;
575
		s->verify_result = s->session->verify_result;
576 577 578
		/* CRYPTO_w_unlock(CRYPTO_LOCK_SSL);*/
		ret=1;
		}
579 580 581 582 583 584 585
	else
		{
		if (s->session != NULL)
			{
			SSL_SESSION_free(s->session);
			s->session=NULL;
			}
586 587 588 589 590 591 592 593

		meth=s->ctx->method;
		if (meth != s->method)
			{
			if (!SSL_set_ssl_method(s,meth))
				return(0);
			}
		ret=1;
594
		}
595 596 597
	return(ret);
	}

U
Ulf Möller 已提交
598
long SSL_SESSION_set_timeout(SSL_SESSION *s, long t)
599 600 601 602 603 604
	{
	if (s == NULL) return(0);
	s->timeout=t;
	return(1);
	}

U
Ulf Möller 已提交
605
long SSL_SESSION_get_timeout(SSL_SESSION *s)
606 607 608 609 610
	{
	if (s == NULL) return(0);
	return(s->timeout);
	}

U
Ulf Möller 已提交
611
long SSL_SESSION_get_time(SSL_SESSION *s)
612 613 614 615 616
	{
	if (s == NULL) return(0);
	return(s->time);
	}

U
Ulf Möller 已提交
617
long SSL_SESSION_set_time(SSL_SESSION *s, long t)
618 619 620 621 622 623
	{
	if (s == NULL) return(0);
	s->time=t;
	return(t);
	}

U
Ulf Möller 已提交
624
long SSL_CTX_set_timeout(SSL_CTX *s, long t)
625 626 627 628 629 630 631 632
	{
	long l;
	if (s == NULL) return(0);
	l=s->session_timeout;
	s->session_timeout=t;
	return(l);
	}

U
Ulf Möller 已提交
633
long SSL_CTX_get_timeout(SSL_CTX *s)
634 635 636 637 638
	{
	if (s == NULL) return(0);
	return(s->session_timeout);
	}

639 640 641 642 643 644 645
typedef struct timeout_param_st
	{
	SSL_CTX *ctx;
	long time;
	LHASH *cache;
	} TIMEOUT_PARAM;

U
Ulf Möller 已提交
646
static void timeout(SSL_SESSION *s, TIMEOUT_PARAM *p)
647 648 649
	{
	if ((p->time == 0) || (p->time > (s->time+s->timeout))) /* timeout */
		{
650 651
		/* The reason we don't call SSL_CTX_remove_session() is to
		 * save on locking overhead */
652
		lh_delete(p->cache,s);
653
		SSL_SESSION_list_remove(p->ctx,s);
654 655 656 657 658 659 660
		s->not_resumable=1;
		if (p->ctx->remove_session_cb != NULL)
			p->ctx->remove_session_cb(p->ctx,s);
		SSL_SESSION_free(s);
		}
	}

661 662
static IMPLEMENT_LHASH_DOALL_ARG_FN(timeout, SSL_SESSION *, TIMEOUT_PARAM *)

U
Ulf Möller 已提交
663
void SSL_CTX_flush_sessions(SSL_CTX *s, long t)
664 665 666 667 668
	{
	unsigned long i;
	TIMEOUT_PARAM tp;

	tp.ctx=s;
669
	tp.cache=s->sessions;
670 671 672 673 674
	if (tp.cache == NULL) return;
	tp.time=t;
	CRYPTO_w_lock(CRYPTO_LOCK_SSL_CTX);
	i=tp.cache->down_load;
	tp.cache->down_load=0;
675
	lh_doall_arg(tp.cache, LHASH_DOALL_ARG_FN(timeout), &tp);
676 677 678 679
	tp.cache->down_load=i;
	CRYPTO_w_unlock(CRYPTO_LOCK_SSL_CTX);
	}

U
Ulf Möller 已提交
680
int ssl_clear_bad_session(SSL *s)
681 682 683 684 685 686 687 688 689 690 691
	{
	if (	(s->session != NULL) &&
		!(s->shutdown & SSL_SENT_SHUTDOWN) &&
		!(SSL_in_init(s) || SSL_in_before(s)))
		{
		SSL_CTX_remove_session(s->ctx,s->session);
		return(1);
		}
	else
		return(0);
	}
692 693

/* locked by SSL_CTX in the calling function */
U
Ulf Möller 已提交
694
static void SSL_SESSION_list_remove(SSL_CTX *ctx, SSL_SESSION *s)
695 696 697 698 699 700 701 702 703 704 705 706 707 708 709 710 711 712 713 714 715 716 717 718 719 720 721 722 723 724 725 726
	{
	if ((s->next == NULL) || (s->prev == NULL)) return;

	if (s->next == (SSL_SESSION *)&(ctx->session_cache_tail))
		{ /* last element in list */
		if (s->prev == (SSL_SESSION *)&(ctx->session_cache_head))
			{ /* only one element in list */
			ctx->session_cache_head=NULL;
			ctx->session_cache_tail=NULL;
			}
		else
			{
			ctx->session_cache_tail=s->prev;
			s->prev->next=(SSL_SESSION *)&(ctx->session_cache_tail);
			}
		}
	else
		{
		if (s->prev == (SSL_SESSION *)&(ctx->session_cache_head))
			{ /* first element in list */
			ctx->session_cache_head=s->next;
			s->next->prev=(SSL_SESSION *)&(ctx->session_cache_head);
			}
		else
			{ /* middle of list */
			s->next->prev=s->prev;
			s->prev->next=s->next;
			}
		}
	s->prev=s->next=NULL;
	}

U
Ulf Möller 已提交
727
static void SSL_SESSION_list_add(SSL_CTX *ctx, SSL_SESSION *s)
728 729 730 731 732 733 734 735 736 737 738 739 740 741 742 743 744 745 746 747
	{
	if ((s->next != NULL) && (s->prev != NULL))
		SSL_SESSION_list_remove(ctx,s);

	if (ctx->session_cache_head == NULL)
		{
		ctx->session_cache_head=s;
		ctx->session_cache_tail=s;
		s->prev=(SSL_SESSION *)&(ctx->session_cache_head);
		s->next=(SSL_SESSION *)&(ctx->session_cache_tail);
		}
	else
		{
		s->next=ctx->session_cache_head;
		s->next->prev=s;
		s->prev=(SSL_SESSION *)&(ctx->session_cache_head);
		ctx->session_cache_head=s;
		}
	}