From: Bradley Nicholes Date: Fri, 2 Apr 2004 23:17:29 +0000 (+0000) Subject: Stop locking all of the connections while trying to find an available connection... X-Git-Tag: pre_ajp_proxy~424 X-Git-Url: https://granicus.if.org/sourcecode?a=commitdiff_plain;h=1bb4ed65e2f9d4ac76ae1d75986e3ca29fee0fce;p=apache Stop locking all of the connections while trying to find an available connection that meets the specified criteria. If a connection doesn't meet the criteria, unlock it so that it remains available for other requests. git-svn-id: https://svn.apache.org/repos/asf/httpd/httpd/trunk@103250 13f79535-47bb-0310-9956-ffa450edef68 --- diff --git a/modules/experimental/util_ldap.c b/modules/experimental/util_ldap.c index 54648e50a1..0498e0c689 100644 --- a/modules/experimental/util_ldap.c +++ b/modules/experimental/util_ldap.c @@ -362,18 +362,22 @@ LDAP_DECLARE(util_ldap_connection_t *)util_ldap_connection_find(request_rec *r, */ for (l=st->connections,p=NULL; l; l=l->next) { #if APR_HAS_THREADS - if ( (APR_SUCCESS == apr_thread_mutex_trylock(l->lock)) && -#else - if ( + if (APR_SUCCESS == apr_thread_mutex_trylock(l->lock)) { #endif - l->port == port - && strcmp(l->host, host) == 0 - && ( (!l->binddn && !binddn) || (l->binddn && binddn && !strcmp(l->binddn, binddn)) ) - && ( (!l->bindpw && !bindpw) || (l->bindpw && bindpw && !strcmp(l->bindpw, bindpw)) ) - && l->deref == deref - && l->secure == secure - ) + if ((l->port == port) && (strcmp(l->host, host) == 0) && + ((!l->binddn && !binddn) || (l->binddn && binddn && !strcmp(l->binddn, binddn))) && + ((!l->bindpw && !bindpw) || (l->bindpw && bindpw && !strcmp(l->bindpw, bindpw))) && + (l->deref == deref) && (l->secure == secure)) { + break; + } +#if APR_HAS_THREADS + /* If this connection didn't match the criteria, then we + * need to unlock the mutex so it is available to be reused. + */ + apr_thread_mutex_unlock(l->lock); + } +#endif p = l; } @@ -383,21 +387,25 @@ LDAP_DECLARE(util_ldap_connection_t *)util_ldap_connection_find(request_rec *r, if (!l) { for (l=st->connections,p=NULL; l; l=l->next) { #if APR_HAS_THREADS - if ( (APR_SUCCESS == apr_thread_mutex_trylock(l->lock)) && -#else - if ( + if (APR_SUCCESS == apr_thread_mutex_trylock(l->lock)) { + #endif - l->port == port - && strcmp(l->host, host) == 0 - && l->deref == deref - && l->secure == secure - ) { + if ((l->port == port) && (strcmp(l->host, host) == 0) && + (l->deref == deref) && (l->secure == secure)) { + /* the bind credentials have changed */ l->bound = 0; l->binddn = apr_pstrdup(st->pool, binddn); l->bindpw = apr_pstrdup(st->pool, bindpw); break; } +#if APR_HAS_THREADS + /* If this connection didn't match the criteria, then we + * need to unlock the mutex so it is available to be reused. + */ + apr_thread_mutex_unlock(l->lock); + } +#endif p = l; } }