mirrors/php-src
0
0
Fork 0
mirror of https://github.com/php/php-src.git synced 2024-11-25 02:44:58 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fix crypto stream timeout regressions

Browse Source
This commit is contained in:
Daniel Lowrey 2015-03-09 15:53:26 -06:00
parent 9af1383a3f
commit bbfd4a5e62
1 changed files with 19 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

37
ext/openssl/xp_ssl.c
View File

@ -200,21 +200,22 @@ static size_t php_openssl_sockop_io(int read, php_stream *stream, char *buf, siz
if (sslsock->ssl_active) { if (sslsock->ssl_active) {
int retry = 1; int retry = 1;
struct timeval start_time; struct timeval start_time;
struct timeval *timeout; struct timeval *timeout = NULL;
int blocked = sslsock->s.is_blocked; int began_blocked = sslsock->s.is_blocked;
int has_timeout = 0; int has_timeout = 0;
/* Begin by making the socket non-blocking. This allows us to check the timeout. */ /* never use a timeout with non-blocking sockets */
if (SUCCESS == php_set_sock_blocking(sslsock->s.socket, 0 TSRMLS_CC)) { if (began_blocked && &sslsock->s.timeout) {
timeout = &sslsock->s.timeout;
}
if (timeout && php_set_sock_blocking(sslsock->s.socket, 0 TSRMLS_CC) == SUCCESS) {
sslsock->s.is_blocked = 0; sslsock->s.is_blocked = 0;
} }
/* Get the timeout value (and make sure we are to check it. */ if (!sslsock->s.is_blocked && timeout && (timeout->tv_sec || timeout->tv_usec)) {
timeout = sslsock->is_client ? &sslsock->connect_timeout : &sslsock->s.timeout; has_timeout = 1;
has_timeout = !sslsock->s.is_blocked && (timeout->tv_sec || timeout->tv_usec); /* gettimeofday is not monotonic; using it here is not strictly correct */
/* gettimeofday is not monotonic; using it here is not strictly correct */
if (has_timeout) {
gettimeofday(&start_time, NULL); gettimeofday(&start_time, NULL);
} }
@ -227,15 +228,16 @@ static size_t php_openssl_sockop_io(int read, php_stream *stream, char *buf, siz
gettimeofday(&cur_time, NULL); gettimeofday(&cur_time, NULL);
/* Determine how much time we've taken so far. */ /* Determine how much time we've taken so far. */
elapsed_time = subtract_timeval( cur_time, start_time ); elapsed_time = subtract_timeval(cur_time, start_time);
/* and return an error if we've taken too long. */ /* and return an error if we've taken too long. */
if (compare_timeval( elapsed_time, *timeout) > 0 ) { if (compare_timeval(elapsed_time, *timeout) > 0 ) {
/* If the socket was originally blocking, set it back. */ /* If the socket was originally blocking, set it back. */
if (blocked) { if (began_blocked) {
php_set_sock_blocking(sslsock->s.socket, 1 TSRMLS_CC); php_set_sock_blocking(sslsock->s.socket, 1 TSRMLS_CC);
sslsock->s.is_blocked = 1; sslsock->s.is_blocked = 1;
} }
sslsock->s.timeout_event = 1;
return -1; return -1;
} }
} }
@ -275,7 +277,7 @@ static size_t php_openssl_sockop_io(int read, php_stream *stream, char *buf, siz
/* Now, if we have to wait some time, and we're supposed to be blocking, wait for the socket to become /* Now, if we have to wait some time, and we're supposed to be blocking, wait for the socket to become
* available. Now, php_pollfd_for uses select to wait up to our time_left value only... * available. Now, php_pollfd_for uses select to wait up to our time_left value only...
*/ */
if (retry && blocked) { if (retry && began_blocked) {
if (read) { if (read) {
php_pollfd_for(sslsock->s.socket, (err == SSL_ERROR_WANT_WRITE) ? php_pollfd_for(sslsock->s.socket, (err == SSL_ERROR_WANT_WRITE) ?
(POLLOUT|POLLPRI) : (POLLIN|POLLPRI), has_timeout ? &left_time : NULL); (POLLOUT|POLLPRI) : (POLLIN|POLLPRI), has_timeout ? &left_time : NULL);
@ -286,7 +288,7 @@ static size_t php_openssl_sockop_io(int read, php_stream *stream, char *buf, siz
} }
} else { } else {
/* Else, if we got bytes back, check for possible errors. */ /* Else, if we got bytes back, check for possible errors. */
int err = SSL_get_error(sslsock->ssl_handle, nr_bytes ); int err = SSL_get_error(sslsock->ssl_handle, nr_bytes);
/* If we didn't get any error, then let's return it to PHP. */ /* If we didn't get any error, then let's return it to PHP. */
if (err == SSL_ERROR_NONE) { if (err == SSL_ERROR_NONE) {
@ -294,7 +296,7 @@ static size_t php_openssl_sockop_io(int read, php_stream *stream, char *buf, siz
} }
/* Otherwise, we need to wait again (up to time_left or we get an error) */ /* Otherwise, we need to wait again (up to time_left or we get an error) */
if (blocked) { if (began_blocked) {
if (read) { if (read) {
php_pollfd_for(sslsock->s.socket, (err == SSL_ERROR_WANT_WRITE) ? php_pollfd_for(sslsock->s.socket, (err == SSL_ERROR_WANT_WRITE) ?
(POLLOUT|POLLPRI) : (POLLIN|POLLPRI), has_timeout ? &left_time : NULL); (POLLOUT|POLLPRI) : (POLLIN|POLLPRI), has_timeout ? &left_time : NULL);
@ -313,8 +315,7 @@ static size_t php_openssl_sockop_io(int read, php_stream *stream, char *buf, siz
} }
/* And if we were originally supposed to be blocking, let's reset the socket to that. */ /* And if we were originally supposed to be blocking, let's reset the socket to that. */
if (blocked) { if (began_blocked && php_set_sock_blocking(sslsock->s.socket, 1 TSRMLS_CC) == SUCCESS) {
php_set_sock_blocking(sslsock->s.socket, 1 TSRMLS_CC);
sslsock->s.is_blocked = 1; sslsock->s.is_blocked = 1;
} }
} else { } else {