Introduce the functions RECORD_LAYER_release, RECORD_LAYER_read_pending, and

RECORD_LAYER_write_pending.

Reviewed-by: Richard Levitte <levitte@openssl.org>
This commit is contained in:
Matt Caswell 2015-02-02 12:18:03 +00:00
parent af9752e5fa
commit f161995e0e
5 changed files with 26 additions and 8 deletions

View file

@ -167,6 +167,9 @@ typedef struct record_layer_st {
#define RECORD_LAYER_get_wrec(rl) (&(rl)->wrec) #define RECORD_LAYER_get_wrec(rl) (&(rl)->wrec)
void RECORD_LAYER_clear(RECORD_LAYER *rl); void RECORD_LAYER_clear(RECORD_LAYER *rl);
void RECORD_LAYER_release(RECORD_LAYER *rl);
int RECORD_LAYER_read_pending(RECORD_LAYER *rl);
int RECORD_LAYER_write_pending(RECORD_LAYER *rl);
__owur int ssl23_read_bytes(SSL *s, int n); __owur int ssl23_read_bytes(SSL *s, int n);
__owur int ssl23_write_bytes(SSL *s); __owur int ssl23_write_bytes(SSL *s);
__owur int ssl3_write_bytes(SSL *s, int type, const void *buf, int len); __owur int ssl3_write_bytes(SSL *s, int type, const void *buf, int len);

View file

@ -159,6 +159,25 @@ void RECORD_LAYER_clear(RECORD_LAYER *rl)
rl->s = s; rl->s = s;
} }
void RECORD_LAYER_release(RECORD_LAYER *rl)
{
if (SSL3_BUFFER_is_initialised(&rl->rbuf))
ssl3_release_read_buffer(rl->s);
if (SSL3_BUFFER_is_initialised(&rl->wbuf))
ssl3_release_write_buffer(rl->s);
SSL3_RECORD_release(&rl->rrec);
}
int RECORD_LAYER_read_pending(RECORD_LAYER *rl)
{
return SSL3_BUFFER_get_left(&rl->rbuf) != 0;
}
int RECORD_LAYER_write_pending(RECORD_LAYER *rl)
{
return SSL3_BUFFER_get_left(&rl->wbuf) != 0;
}
int ssl3_read_n(SSL *s, int n, int max, int extend) int ssl3_read_n(SSL *s, int n, int max, int extend)
{ {
/* /*

View file

@ -4473,8 +4473,8 @@ int ssl3_renegotiate_check(SSL *s)
int ret = 0; int ret = 0;
if (s->s3->renegotiate) { if (s->s3->renegotiate) {
if ((SSL3_BUFFER_get_left(RECORD_LAYER_get_rbuf(&s->rlayer)) == 0) if (!RECORD_LAYER_read_pending(&s->rlayer)
&& (SSL3_BUFFER_get_left(RECORD_LAYER_get_wbuf(&s->rlayer)) == 0) && !RECORD_LAYER_write_pending(&s->rlayer)
&& !SSL_in_init(s)) { && !SSL_in_init(s)) {
/* /*
* if we are the server, and we have sent a 'RENEGOTIATE' * if we are the server, and we have sent a 'RENEGOTIATE'

View file

@ -179,7 +179,7 @@ int ssl3_send_alert(SSL *s, int level, int desc)
s->s3->alert_dispatch = 1; s->s3->alert_dispatch = 1;
s->s3->send_alert[0] = level; s->s3->send_alert[0] = level;
s->s3->send_alert[1] = desc; s->s3->send_alert[1] = desc;
if (SSL3_BUFFER_get_left(RECORD_LAYER_get_wbuf(&s->rlayer)) == 0) { if (!RECORD_LAYER_write_pending(&s->rlayer)) {
/* data still being written out? */ /* data still being written out? */
return s->method->ssl_dispatch_alert(s); return s->method->ssl_dispatch_alert(s);
} }

View file

@ -603,11 +603,7 @@ void SSL_free(SSL *s)
if (s->method != NULL) if (s->method != NULL)
s->method->ssl_free(s); s->method->ssl_free(s);
if (SSL3_BUFFER_is_initialised(RECORD_LAYER_get_rbuf(&s->rlayer))) RECORD_LAYER_release(&s->rlayer);
ssl3_release_read_buffer(s);
if (SSL3_BUFFER_is_initialised(RECORD_LAYER_get_wbuf(&s->rlayer)))
ssl3_release_write_buffer(s);
SSL3_RECORD_release(RECORD_LAYER_get_rrec(&s->rlayer));
if (s->ctx) if (s->ctx)
SSL_CTX_free(s->ctx); SSL_CTX_free(s->ctx);