From: Howard Chu <hyc@openldap.org>
Date: Fri, 22 Apr 2005 22:27:29 +0000 (+0000)
Subject: Add ldap_pvt_thread_pool_purgekey to free all instances of key across
X-Git-Tag: OPENLDAP_AC_BP~818
X-Git-Url: https://git.sur5r.net/?a=commitdiff_plain;h=3f20324ed0ac192926bf33e1e5679e5f2db753aa;p=openldap

Add ldap_pvt_thread_pool_purgekey to free all instances of key across
all threads.
---

diff --git a/include/ldap_pvt_thread.h b/include/ldap_pvt_thread.h
index 6c1b86845b..1ca300bd98 100644
--- a/include/ldap_pvt_thread.h
+++ b/include/ldap_pvt_thread.h
@@ -202,6 +202,9 @@ ldap_pvt_thread_pool_setkey LDAP_P((
 	void *data,
 	ldap_pvt_thread_pool_keyfree_t *kfree ));
 
+LDAP_F( void )
+ldap_pvt_thread_pool_purgekey LDAP_P(( void *key ));
+
 LDAP_F( void *)
 ldap_pvt_thread_pool_context LDAP_P(( void ));
 
diff --git a/libraries/libldap_r/tpool.c b/libraries/libldap_r/tpool.c
index 31fa541cb8..50bac8d2c1 100644
--- a/libraries/libldap_r/tpool.c
+++ b/libraries/libldap_r/tpool.c
@@ -616,6 +616,30 @@ int ldap_pvt_thread_pool_setkey(
 	return ENOMEM;
 }
 
+/* Free all elements with this key, no matter which thread they're in.
+ * May only be called while the pool is paused.
+ */
+void ldap_pvt_thread_pool_purgekey( void *key )
+{
+	int i, j;
+	ldap_int_thread_key_t *ctx;
+
+	for ( i=0; i<LDAP_MAXTHR; i++ ) {
+		if ( thread_keys[i].ctx ) {
+			ctx = thread_keys[i].ctx;
+			for ( j=0; j<MAXKEYS; j++ ) {
+				if ( ctx[j].ltk_key == key ) {
+					if (ctx[j].ltk_free)
+						ctx[j].ltk_free( ctx[j].ltk_key, ctx[j].ltk_data );
+					ctx[j].ltk_key = NULL;
+					ctx[j].ltk_free = NULL;
+					break;
+				}
+			}
+		}
+	}
+}
+
 /*
  * This is necessary if the caller does not have access to the
  * thread context handle (for example, a slapd plugin calling