xref: /titanic_50/usr/src/cmd/nscd/nscd_nswstate.c (revision 3d0479833b8db89da4bca3e8e8e88f996686aa8e)
1cb5caa98Sdjl /*
2cb5caa98Sdjl  * CDDL HEADER START
3cb5caa98Sdjl  *
4cb5caa98Sdjl  * The contents of this file are subject to the terms of the
5cb5caa98Sdjl  * Common Development and Distribution License (the "License").
6cb5caa98Sdjl  * You may not use this file except in compliance with the License.
7cb5caa98Sdjl  *
8cb5caa98Sdjl  * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
9cb5caa98Sdjl  * or http://www.opensolaris.org/os/licensing.
10cb5caa98Sdjl  * See the License for the specific language governing permissions
11cb5caa98Sdjl  * and limitations under the License.
12cb5caa98Sdjl  *
13cb5caa98Sdjl  * When distributing Covered Code, include this CDDL HEADER in each
14cb5caa98Sdjl  * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
15cb5caa98Sdjl  * If applicable, add the following below this CDDL HEADER, with the
16cb5caa98Sdjl  * fields enclosed by brackets "[]" replaced with your own identifying
17cb5caa98Sdjl  * information: Portions Copyright [yyyy] [name of copyright owner]
18cb5caa98Sdjl  *
19cb5caa98Sdjl  * CDDL HEADER END
20cb5caa98Sdjl  */
21cb5caa98Sdjl /*
22bf1e3beeSmichen  * Copyright 2007 Sun Microsystems, Inc.  All rights reserved.
23cb5caa98Sdjl  * Use is subject to license terms.
24cb5caa98Sdjl  */
25cb5caa98Sdjl 
26cb5caa98Sdjl #pragma ident	"%Z%%M%	%I%	%E% SMI"
27cb5caa98Sdjl 
28cb5caa98Sdjl #include <stdio.h>
29cb5caa98Sdjl #include <stdlib.h>
30cb5caa98Sdjl #include <assert.h>
31cb5caa98Sdjl #include <string.h>
32cb5caa98Sdjl #include "nscd_switch.h"
33cb5caa98Sdjl #include "nscd_log.h"
34cb5caa98Sdjl 
35cb5caa98Sdjl /*
36cb5caa98Sdjl  * nscd_nsw_state_t list for each nss database. Protected
37cb5caa98Sdjl  * by the readers/writer lock nscd_nsw_state_base_lock.
38cb5caa98Sdjl  */
39cb5caa98Sdjl nscd_nsw_state_base_t **nscd_nsw_state_base;
40cb5caa98Sdjl static rwlock_t nscd_nsw_state_base_lock = DEFAULTRWLOCK;
41cb5caa98Sdjl 
42cb5caa98Sdjl static void
43cb5caa98Sdjl _nscd_free_nsw_state(
44cb5caa98Sdjl 	nscd_nsw_state_t	*s)
45cb5caa98Sdjl {
46cb5caa98Sdjl 
47cb5caa98Sdjl 	int			i;
48cb5caa98Sdjl 	char			*me = "_nscd_free_nsw_state";
49cb5caa98Sdjl 
50cb5caa98Sdjl 	_NSCD_LOG(NSCD_LOG_NSW_STATE, NSCD_LOG_LEVEL_DEBUG)
51cb5caa98Sdjl 	(me, "freeing nsw state = %p\n", s);
52cb5caa98Sdjl 
53cb5caa98Sdjl 	if (s == NULL)
54cb5caa98Sdjl 		return;
55cb5caa98Sdjl 
56cb5caa98Sdjl 	if (s->nsw_cfg_p != NULL)
57cb5caa98Sdjl 		/*
58cb5caa98Sdjl 		 * an nsw state without base does not reference
59cb5caa98Sdjl 		 * count the nsw config data (ie not using a
60cb5caa98Sdjl 		 * shared one), so the one created for it should
61cb5caa98Sdjl 		 * be freed
62cb5caa98Sdjl 		 */
63cb5caa98Sdjl 		if ((*s->nsw_cfg_p)->nobase != 1)
64cb5caa98Sdjl 			_nscd_release((nscd_acc_data_t *)s->nsw_cfg_p);
65cb5caa98Sdjl 		else
66*3d047983Smichen 			(void) _nscd_set((nscd_acc_data_t *)s->nsw_cfg_p, NULL);
67cb5caa98Sdjl 
68cb5caa98Sdjl 	if (s->be_db_pp != NULL) {
69cb5caa98Sdjl 		for (i = 0; i < s->max_src; i++) {
70cb5caa98Sdjl 			if (s->be_db_pp[i] == NULL)
71cb5caa98Sdjl 				continue;
72cb5caa98Sdjl 			_nscd_release((nscd_acc_data_t *)s->be_db_pp[i]);
73cb5caa98Sdjl 			_NSCD_LOG(NSCD_LOG_NSW_STATE, NSCD_LOG_LEVEL_DEBUG)
74cb5caa98Sdjl 			(me, "release db be ptr %p\n", s->be_db_pp[i]);
75cb5caa98Sdjl 		}
76cb5caa98Sdjl 		free(s->be_db_pp);
77cb5caa98Sdjl 	}
78cb5caa98Sdjl 
79cb5caa98Sdjl 	if (s->be != NULL) {
80cb5caa98Sdjl 		for (i = 0; i < s->max_src; i++) {
81cb5caa98Sdjl 			if (s->be[i] == NULL)
82cb5caa98Sdjl 				continue;
83cb5caa98Sdjl 			if (s->getent == 1)
84cb5caa98Sdjl 				(void) NSS_INVOKE_DBOP(s->be[i],
85cb5caa98Sdjl 				    NSS_DBOP_ENDENT, 0);
86cb5caa98Sdjl 			(void) NSS_INVOKE_DBOP(s->be[i],
87cb5caa98Sdjl 			    NSS_DBOP_DESTRUCTOR, 0);
88cb5caa98Sdjl 		}
89cb5caa98Sdjl 		free(s->be);
90cb5caa98Sdjl 	}
91cb5caa98Sdjl 
92bf1e3beeSmichen 	if (s->be_constr != NULL)
93bf1e3beeSmichen 		free(s->be_constr);
94bf1e3beeSmichen 
95cb5caa98Sdjl 	s->base = NULL;
96cb5caa98Sdjl 
97cb5caa98Sdjl 	_NSCD_LOG(NSCD_LOG_NSW_STATE, NSCD_LOG_LEVEL_DEBUG)
98cb5caa98Sdjl 	(me, "nsw state %p freed \n", s);
99cb5caa98Sdjl 
100cb5caa98Sdjl 	free(s);
101cb5caa98Sdjl }
102cb5caa98Sdjl 
103cb5caa98Sdjl static void
104cb5caa98Sdjl _nscd_free_nsw_state_base(
105cb5caa98Sdjl 	nscd_acc_data_t		*data)
106cb5caa98Sdjl {
107cb5caa98Sdjl 	nscd_nsw_state_base_t	*base = (nscd_nsw_state_base_t *)data;
108cb5caa98Sdjl 	nscd_nsw_state_t	*s, *ts;
109cb5caa98Sdjl 	int			i;
110cb5caa98Sdjl 	char			*me = "_nscd_free_nsw_state_base";
111cb5caa98Sdjl 
112cb5caa98Sdjl 	_NSCD_LOG(NSCD_LOG_NSW_STATE | NSCD_LOG_CONFIG, NSCD_LOG_LEVEL_DEBUG)
113cb5caa98Sdjl 	(me, "freeing db state base %p\n", base);
114cb5caa98Sdjl 
115cb5caa98Sdjl 	if (base == NULL)
116cb5caa98Sdjl 		return;
117cb5caa98Sdjl 
118cb5caa98Sdjl 	for (i = 0; i < 2; i++) {
119cb5caa98Sdjl 		if (i == 1)
120cb5caa98Sdjl 			s = base->nsw_state.first;
121cb5caa98Sdjl 		else
122cb5caa98Sdjl 			s = base->nsw_state_thr.first;
123cb5caa98Sdjl 
124cb5caa98Sdjl 		while (s != NULL) {
125cb5caa98Sdjl 			ts = s->next;
126cb5caa98Sdjl 			_nscd_free_nsw_state(s);
127cb5caa98Sdjl 			s = ts;
128cb5caa98Sdjl 		}
129cb5caa98Sdjl 	}
130cb5caa98Sdjl 
131cb5caa98Sdjl 	_NSCD_LOG(NSCD_LOG_NSW_STATE | NSCD_LOG_CONFIG, NSCD_LOG_LEVEL_DEBUG)
132cb5caa98Sdjl 	(me, "nsw state base %p freed \n", base);
133cb5caa98Sdjl }
134cb5caa98Sdjl 
135cb5caa98Sdjl void
136cb5caa98Sdjl _nscd_free_all_nsw_state_base()
137cb5caa98Sdjl {
138cb5caa98Sdjl 	nscd_nsw_state_base_t	*base;
139cb5caa98Sdjl 	int			i;
140cb5caa98Sdjl 	char			*me = "_nscd_free_all_nsw_state_base";
141cb5caa98Sdjl 
142cb5caa98Sdjl 	_NSCD_LOG(NSCD_LOG_NSW_STATE | NSCD_LOG_CONFIG, NSCD_LOG_LEVEL_DEBUG)
143cb5caa98Sdjl 	(me, "freeing all db state base\n");
144cb5caa98Sdjl 
145cb5caa98Sdjl 	(void) rw_wrlock(&nscd_nsw_state_base_lock);
146cb5caa98Sdjl 	for (i = 0; i < NSCD_NUM_DB; i++) {
147cb5caa98Sdjl 
148cb5caa98Sdjl 		base = nscd_nsw_state_base[i];
149cb5caa98Sdjl 		_NSCD_LOG(NSCD_LOG_NSW_STATE | NSCD_LOG_CONFIG,
150cb5caa98Sdjl 		    NSCD_LOG_LEVEL_DEBUG)
151cb5caa98Sdjl 		(me, "freeing db state base (%d) %p \n", i, base);
152cb5caa98Sdjl 
153cb5caa98Sdjl 		if (base == NULL)
154cb5caa98Sdjl 			continue;
155cb5caa98Sdjl 
156cb5caa98Sdjl 		nscd_nsw_state_base[i] = (nscd_nsw_state_base_t *)
157cb5caa98Sdjl 		    _nscd_set((nscd_acc_data_t *)base, NULL);
158cb5caa98Sdjl 	}
159cb5caa98Sdjl 	(void) rw_unlock(&nscd_nsw_state_base_lock);
160cb5caa98Sdjl }
161cb5caa98Sdjl 
162cb5caa98Sdjl static nscd_nsw_state_t *
163cb5caa98Sdjl _nscd_create_nsw_state(
164cb5caa98Sdjl 	nscd_nsw_params_t	*params)
165cb5caa98Sdjl {
166cb5caa98Sdjl 	nscd_nsw_state_t	*s;
167cb5caa98Sdjl 	nscd_nsw_config_t	*nsw_cfg;
168cb5caa98Sdjl 	nscd_db_t		**be_db_p, *be_db;
169cb5caa98Sdjl 	int			i, nobe = 1;
170cb5caa98Sdjl 	char			*me = "_nscd_create_nsw_state";
171cb5caa98Sdjl 
172cb5caa98Sdjl 
173cb5caa98Sdjl 	_NSCD_LOG(NSCD_LOG_NSW_STATE, NSCD_LOG_LEVEL_DEBUG)
174cb5caa98Sdjl 	(me, "creating nsw state...\n");
175cb5caa98Sdjl 
176cb5caa98Sdjl 	s = calloc(1, sizeof (nscd_nsw_state_t));
177cb5caa98Sdjl 	if (s == NULL) {
178cb5caa98Sdjl 		if ((*s->nsw_cfg_p)->nobase  != 1)
179cb5caa98Sdjl 			_nscd_release((nscd_acc_data_t *)params->nswcfg);
180cb5caa98Sdjl 		_NSCD_LOG(NSCD_LOG_NSW_STATE, NSCD_LOG_LEVEL_ERROR)
181cb5caa98Sdjl 		(me, "not able to allocate a nsw state\n");
182cb5caa98Sdjl 		return (NULL);
183cb5caa98Sdjl 	} else
184cb5caa98Sdjl 		_NSCD_LOG(NSCD_LOG_NSW_STATE, NSCD_LOG_LEVEL_DEBUG)
185cb5caa98Sdjl 		(me, "nsw state %p allocated\n", s);
186cb5caa98Sdjl 
187cb5caa98Sdjl 	s->dbi = params->dbi;
188cb5caa98Sdjl 	s->next = NULL;
189cb5caa98Sdjl 
190cb5caa98Sdjl 	nsw_cfg = *params->nswcfg;
191cb5caa98Sdjl 
192cb5caa98Sdjl 	s->nsw_cfg_p = params->nswcfg;
193cb5caa98Sdjl 	s->config = nsw_cfg->nsw_config;
194cb5caa98Sdjl 	s->max_src = nsw_cfg->max_src;
195cb5caa98Sdjl 	s->p = params->p;
196cb5caa98Sdjl 
197cb5caa98Sdjl 	s->be = calloc(s->max_src, sizeof (nss_backend_t **));
198cb5caa98Sdjl 	if (s->be == NULL) {
199cb5caa98Sdjl 		_NSCD_LOG(NSCD_LOG_NSW_STATE, NSCD_LOG_LEVEL_ERROR)
200cb5caa98Sdjl 		(me, "not able to allocate s->be\n");
201cb5caa98Sdjl 
202cb5caa98Sdjl 		_nscd_free_nsw_state(s);
203cb5caa98Sdjl 		return (NULL);
204cb5caa98Sdjl 	} else {
205cb5caa98Sdjl 		_NSCD_LOG(NSCD_LOG_NSW_STATE, NSCD_LOG_LEVEL_DEBUG)
206cb5caa98Sdjl 		(me, "db be array %p allocated\n", s->be);
207cb5caa98Sdjl 	}
208cb5caa98Sdjl 
209bf1e3beeSmichen 	s->be_constr = (nss_backend_constr_t *)calloc(s->max_src,
210bf1e3beeSmichen 	    sizeof (nss_backend_constr_t));
211bf1e3beeSmichen 	if (s->be_constr == NULL) {
212bf1e3beeSmichen 		_NSCD_LOG(NSCD_LOG_NSW_STATE, NSCD_LOG_LEVEL_ERROR)
213bf1e3beeSmichen 		(me, "not able to allocate s->be_constr\n");
214bf1e3beeSmichen 
215bf1e3beeSmichen 		_nscd_free_nsw_state(s);
216bf1e3beeSmichen 		return (NULL);
217bf1e3beeSmichen 	} else {
218bf1e3beeSmichen 		_NSCD_LOG(NSCD_LOG_NSW_STATE, NSCD_LOG_LEVEL_DEBUG)
219bf1e3beeSmichen 		(me, "db be constructor array %p allocated\n", s->be_constr);
220bf1e3beeSmichen 	}
221bf1e3beeSmichen 
222cb5caa98Sdjl 	s->be_db_pp = calloc(s->max_src, sizeof (nscd_db_t ***));
223cb5caa98Sdjl 	if (s->be_db_pp == NULL) {
224cb5caa98Sdjl 		_NSCD_LOG(NSCD_LOG_NSW_STATE, NSCD_LOG_LEVEL_ERROR)
225cb5caa98Sdjl 		(me, "not able to allocate s->be_db_pp\n");
226cb5caa98Sdjl 		_nscd_free_nsw_state(s);
227cb5caa98Sdjl 		return (NULL);
228cb5caa98Sdjl 	} else {
229cb5caa98Sdjl 		_NSCD_LOG(NSCD_LOG_NSW_STATE, NSCD_LOG_LEVEL_DEBUG)
230cb5caa98Sdjl 		(me, "be_db_pp array %p allocated\n", s->be_db_pp);
231cb5caa98Sdjl 	}
232cb5caa98Sdjl 
233cb5caa98Sdjl 	/* create the source:database backends */
234cb5caa98Sdjl 	for (i = 0;  i < s->max_src;  i++) {
235cb5caa98Sdjl 		nss_backend_t		*be;
236cb5caa98Sdjl 		int			srci;
237cb5caa98Sdjl 		char			*srcn;
238cb5caa98Sdjl 		const char		*dbn;
239cb5caa98Sdjl 		struct __nsw_lookup_v1	*lkp;
240cb5caa98Sdjl 		const nscd_db_entry_t	*dbe;
241cb5caa98Sdjl 		nscd_be_info_t		*be_info;
242cb5caa98Sdjl 
243cb5caa98Sdjl 		if (i == 0)
244cb5caa98Sdjl 			lkp = s->config->lookups;
245cb5caa98Sdjl 		else
246cb5caa98Sdjl 			lkp = lkp->next;
247cb5caa98Sdjl 		if (lkp == NULL) {
248cb5caa98Sdjl 			_NSCD_LOG(NSCD_LOG_NSW_STATE, NSCD_LOG_LEVEL_ERROR)
249cb5caa98Sdjl 			(me, "error: lkp is NULL\n");
250cb5caa98Sdjl 			_nscd_free_nsw_state(s);
251cb5caa98Sdjl 			return (NULL);
252cb5caa98Sdjl 		}
253cb5caa98Sdjl 
254cb5caa98Sdjl 		srci = nsw_cfg->src_idx[i];
255cb5caa98Sdjl 		srcn = lkp->service_name;
256cb5caa98Sdjl 		_NSCD_LOG(NSCD_LOG_NSW_STATE, NSCD_LOG_LEVEL_DEBUG)
257cb5caa98Sdjl 		(me, "source name = %s, index = %d\n", srcn, srci);
258cb5caa98Sdjl 
259cb5caa98Sdjl 		be_db_p = (nscd_db_t **)_nscd_get(
260cb5caa98Sdjl 		    (nscd_acc_data_t *)nscd_src_backend_db[srci]);
261cb5caa98Sdjl 		if (be_db_p == NULL) {
262cb5caa98Sdjl 			_nscd_free_nsw_state(s);
263cb5caa98Sdjl 			return (NULL);
264cb5caa98Sdjl 		}
265cb5caa98Sdjl 		be_db = *be_db_p;
266cb5caa98Sdjl 		s->be_db_pp[i] = be_db_p;
267cb5caa98Sdjl 		_NSCD_LOG(NSCD_LOG_NSW_STATE, NSCD_LOG_LEVEL_DEBUG)
268cb5caa98Sdjl 		(me, "be db ptr array %p referenced\n", be_db_p);
269cb5caa98Sdjl 
270cb5caa98Sdjl 		be_info = NULL;
271cb5caa98Sdjl 		be = NULL;
272cb5caa98Sdjl 		dbn = params->p.name;
273cb5caa98Sdjl 		dbe = _nscd_get_db_entry(be_db, NSCD_DATA_BACKEND_INFO,
274cb5caa98Sdjl 		    (const char *)dbn, NSCD_GET_FIRST_DB_ENTRY, 0);
275cb5caa98Sdjl 		if (dbe != NULL)
276cb5caa98Sdjl 			be_info = (nscd_be_info_t *)*(dbe->data_array);
277cb5caa98Sdjl 
278cb5caa98Sdjl 		if (be_info == NULL || be_info->be_constr == NULL) {
279cb5caa98Sdjl 			_NSCD_LOG(NSCD_LOG_NSW_STATE, NSCD_LOG_LEVEL_DEBUG)
280cb5caa98Sdjl 			(me, "no backend info or be_constr is NULL "
281cb5caa98Sdjl 			    "for <%s : %s>\n", NSCD_NSW_SRC_NAME(srci),
282cb5caa98Sdjl 			    dbn);
283bf1e3beeSmichen 		} else {
284bf1e3beeSmichen 			s->be_constr[i] = be_info->be_constr;
285cb5caa98Sdjl 			be = (be_info->be_constr)(dbn,
286cb5caa98Sdjl 			    NSCD_NSW_SRC_NAME(srci), 0);
287bf1e3beeSmichen 			if (be == NULL)
288bf1e3beeSmichen 				s->recheck_be = nscd_true;
289bf1e3beeSmichen 		}
290cb5caa98Sdjl 
291cb5caa98Sdjl 		if (be == NULL) {
292cb5caa98Sdjl 			_NSCD_LOG(NSCD_LOG_NSW_STATE, NSCD_LOG_LEVEL_ERROR)
293cb5caa98Sdjl 			(me, "not able to init be for <%s : %s>\n",
294cb5caa98Sdjl 			    NSCD_NSW_SRC_NAME(srci), dbn);
295cb5caa98Sdjl 
296cb5caa98Sdjl 			_NSCD_LOG(NSCD_LOG_NSW_STATE, NSCD_LOG_LEVEL_DEBUG)
297cb5caa98Sdjl 			(me, "releasing db be ptr %p\n", be_db_p);
298cb5caa98Sdjl 
299cb5caa98Sdjl 			_nscd_release((nscd_acc_data_t *)be_db_p);
300cb5caa98Sdjl 			s->be_db_pp[i] = NULL;
301cb5caa98Sdjl 
302cb5caa98Sdjl 			continue;
303cb5caa98Sdjl 		}
304cb5caa98Sdjl 
305cb5caa98Sdjl 		s->be[i] = be;
306cb5caa98Sdjl 		nobe = 0;
307cb5caa98Sdjl 	}
308cb5caa98Sdjl 
309cb5caa98Sdjl 	if (nobe == 1) {
310cb5caa98Sdjl 		_NSCD_LOG(NSCD_LOG_NSW_STATE, NSCD_LOG_LEVEL_DEBUG)
311cb5caa98Sdjl 		(me, "NO backend found, returning NULL\n");
312cb5caa98Sdjl 
313cb5caa98Sdjl 		_nscd_free_nsw_state(s);
314cb5caa98Sdjl 		return (NULL);
315cb5caa98Sdjl 	}
316cb5caa98Sdjl 
317cb5caa98Sdjl 	return (s);
318cb5caa98Sdjl }
319cb5caa98Sdjl 
320bf1e3beeSmichen /*
321bf1e3beeSmichen  * Try to initialize the backend instances one more time
322bf1e3beeSmichen  * in case the dependencies the backend libraries depend
323bf1e3beeSmichen  * on are now available
324bf1e3beeSmichen  */
325bf1e3beeSmichen static void
326bf1e3beeSmichen check_be_array(
327bf1e3beeSmichen 	nscd_nsw_state_t	*s)
328bf1e3beeSmichen {
329bf1e3beeSmichen 	int			i;
330bf1e3beeSmichen 	char			*dbn;
331bf1e3beeSmichen 	char			*srcn;
332bf1e3beeSmichen 	struct __nsw_lookup_v1	*lkp;
333bf1e3beeSmichen 
334bf1e3beeSmichen 	dbn = NSCD_NSW_DB_NAME(s->dbi);
335bf1e3beeSmichen 
336bf1e3beeSmichen 	s->recheck_be = nscd_false;
337bf1e3beeSmichen 	for (i = 0;  i < s->max_src;  i++) {
338bf1e3beeSmichen 
339bf1e3beeSmichen 		if (i == 0)
340bf1e3beeSmichen 			lkp = s->config->lookups;
341bf1e3beeSmichen 		else
342bf1e3beeSmichen 			lkp = lkp->next;
343bf1e3beeSmichen 		if (lkp == NULL)
344bf1e3beeSmichen 			return;
345bf1e3beeSmichen 
346bf1e3beeSmichen 		srcn = lkp->service_name;
347bf1e3beeSmichen 
348bf1e3beeSmichen 		/*
349bf1e3beeSmichen 		 * it is possible that 's->be[i]' could not be
350bf1e3beeSmichen 		 * initialized earlier due to a dependency not
351bf1e3beeSmichen 		 * yet available (e.g., nis on domain name),
352bf1e3beeSmichen 		 * try to initialize one more time
353bf1e3beeSmichen 		 */
354bf1e3beeSmichen 		if (s->be[i] == NULL && s->be_constr[i] != NULL) {
355bf1e3beeSmichen 			s->be[i] = (s->be_constr[i])(dbn, srcn, 0);
356bf1e3beeSmichen 			if (s->be[i] == NULL)
357bf1e3beeSmichen 				s->recheck_be = nscd_true;
358bf1e3beeSmichen 		}
359bf1e3beeSmichen 	}
360bf1e3beeSmichen }
361bf1e3beeSmichen 
362cb5caa98Sdjl static nscd_rc_t
363cb5caa98Sdjl _get_nsw_state_int(
364cb5caa98Sdjl 	nss_db_root_t		*rootp,
365cb5caa98Sdjl 	nscd_nsw_params_t	*params,
366cb5caa98Sdjl 	thread_t		*tid)
367cb5caa98Sdjl {
368cb5caa98Sdjl 
369cb5caa98Sdjl 	nscd_nsw_state_t	*ret = NULL;
370cb5caa98Sdjl 	nscd_nsw_config_t	**nswcfg;
371cb5caa98Sdjl 	nscd_nsw_state_base_t	*base;
372cb5caa98Sdjl 	nscd_state_ctrl_t	*ctrl_p;
373cb5caa98Sdjl 	int			thread_only = 0, wait_cond = 0;
374cb5caa98Sdjl 	char			*me = "_get_nsw_state_int";
375cb5caa98Sdjl 	int			dbi;
376cb5caa98Sdjl 	nscd_rc_t		rc;
377cb5caa98Sdjl 
378cb5caa98Sdjl 	dbi = params->dbi;
379cb5caa98Sdjl 
380cb5caa98Sdjl 	/*
381cb5caa98Sdjl 	 * no nsw state will be reused, if asked to use
382cb5caa98Sdjl 	 * default config. So create the new structures
383cb5caa98Sdjl 	 * used by the switch engine and the new nsw state
384cb5caa98Sdjl 	 */
385cb5caa98Sdjl 	if (params->p.flags & NSS_USE_DEFAULT_CONFIG) {
386ad0e80f7Smichen 		rc = _nscd_create_sw_struct(dbi, -1, (char *)params->p.name,
387cb5caa98Sdjl 		    (char *)params->p.default_config, NULL, params);
388cb5caa98Sdjl 		if (rc != NSCD_SUCCESS)
389cb5caa98Sdjl 			return (rc);
390cb5caa98Sdjl 
391cb5caa98Sdjl 		_NSCD_LOG(NSCD_LOG_NSW_STATE, NSCD_LOG_LEVEL_DEBUG)
392cb5caa98Sdjl 		(me, "no base nsw config created for %s (sources: %s)\n",
393cb5caa98Sdjl 		    params->p.name, params->p.default_config);
394cb5caa98Sdjl 
395cb5caa98Sdjl 		ret = _nscd_create_nsw_state(params);
396cb5caa98Sdjl 		if (ret == NULL)
397cb5caa98Sdjl 			return (NSCD_CREATE_NSW_STATE_FAILED);
398cb5caa98Sdjl 		rootp->s = (struct nss_db_state *)ret;
399cb5caa98Sdjl 		return (NSCD_SUCCESS);
400cb5caa98Sdjl 	}
401cb5caa98Sdjl 
402cb5caa98Sdjl 	/*
403cb5caa98Sdjl 	 * if getting a nsw state for a request from the compat
404cb5caa98Sdjl 	 * backend, create the new switch structures if this
405cb5caa98Sdjl 	 * is the first time around for a passwd, shadow, group,
406cb5caa98Sdjl 	 * audit_user, or user_attr database
407cb5caa98Sdjl 	 */
408cb5caa98Sdjl 	if (params->compati != -1) {
409cb5caa98Sdjl 
410cb5caa98Sdjl 		nscd_nsw_config_t	**nswcfg1;
411cb5caa98Sdjl 		int			i = params->compati;
412cb5caa98Sdjl 
413ad0e80f7Smichen 		dbi = i;
414ad0e80f7Smichen 
415cb5caa98Sdjl 		nswcfg = (nscd_nsw_config_t **)_nscd_get(
416cb5caa98Sdjl 		    (nscd_acc_data_t *)nscd_nsw_config[i]);
417cb5caa98Sdjl 
418cb5caa98Sdjl 		/*
419cb5caa98Sdjl 		 * if nsw data structures not created yet, get the
420cb5caa98Sdjl 		 * config string from the passwd_compat or
421cb5caa98Sdjl 		 * group_compat DB and create the structures
422cb5caa98Sdjl 		 */
423cb5caa98Sdjl 		if (nswcfg == NULL) {
424cb5caa98Sdjl 			nswcfg1 = (nscd_nsw_config_t **)_nscd_get(
425cb5caa98Sdjl 			    (nscd_acc_data_t *)nscd_nsw_config[params->cfgdbi]);
426cb5caa98Sdjl 			if (nswcfg1 == NULL) {
427cb5caa98Sdjl 				_NSCD_LOG(NSCD_LOG_NSW_STATE,
428cb5caa98Sdjl 				    NSCD_LOG_LEVEL_ERROR)
429cb5caa98Sdjl 				(me, "no nsw config for %s\n",
430cb5caa98Sdjl 				    params->p.name);
431cb5caa98Sdjl 				return (NSCD_CREATE_NSW_STATE_FAILED);
432cb5caa98Sdjl 			}
433cb5caa98Sdjl 
434ad0e80f7Smichen 			rc = _nscd_create_sw_struct(i, params->cfgdbi,
435ad0e80f7Smichen 			    params->p.name, (*nswcfg1)->nsw_cfg_str,
436ad0e80f7Smichen 			    NULL, params);
437cb5caa98Sdjl 			_nscd_release((nscd_acc_data_t *)nswcfg1);
438cb5caa98Sdjl 			if (rc != NSCD_SUCCESS)
439cb5caa98Sdjl 				return (rc);
440cb5caa98Sdjl 
441cb5caa98Sdjl 			_NSCD_LOG(NSCD_LOG_NSW_STATE,
442cb5caa98Sdjl 			    NSCD_LOG_LEVEL_DEBUG)
443cb5caa98Sdjl 				(me, "nsw config created for %s (%s)\n",
444cb5caa98Sdjl 				    params->p.name, (*nswcfg1)->nsw_cfg_str);
445cb5caa98Sdjl 		} else
446cb5caa98Sdjl 			_nscd_release((nscd_acc_data_t *)nswcfg);
447cb5caa98Sdjl 	}
448cb5caa98Sdjl 
449cb5caa98Sdjl 	(void) rw_rdlock(&nscd_nsw_state_base_lock);
450cb5caa98Sdjl 	base = nscd_nsw_state_base[dbi];
451cb5caa98Sdjl 	(void) rw_unlock(&nscd_nsw_state_base_lock);
452cb5caa98Sdjl 	if (base == NULL)
453cb5caa98Sdjl 		assert(base != NULL);
454cb5caa98Sdjl 
455cb5caa98Sdjl 	/*
456cb5caa98Sdjl 	 * If list is not empty, return the first one on list.
457cb5caa98Sdjl 	 * Otherwise, create and return a new db state if the
458cb5caa98Sdjl 	 * limit is not reached. if reacehed, wait for the 'one
459cb5caa98Sdjl 	 * is available' signal.
460cb5caa98Sdjl 	 */
461cb5caa98Sdjl 	assert(base == (nscd_nsw_state_base_t *)_nscd_mutex_lock(
462cb5caa98Sdjl 	    (nscd_acc_data_t *)base));
463cb5caa98Sdjl 
464cb5caa98Sdjl 	if (tid == NULL) {
465cb5caa98Sdjl 		ctrl_p = &base->nsw_state;
466cb5caa98Sdjl 	} else {
467cb5caa98Sdjl 		thread_only = 1;
468cb5caa98Sdjl 		ctrl_p = &base->nsw_state_thr;
469cb5caa98Sdjl 
470cb5caa98Sdjl 		_NSCD_LOG_IF(NSCD_LOG_NSW_STATE, NSCD_LOG_LEVEL_DEBUG) {
471cb5caa98Sdjl 			_nscd_logit(me, "per thread nsw state info: \n");
472cb5caa98Sdjl 			_nscd_logit(me, "tid = %d\n", *tid);
473cb5caa98Sdjl 			_nscd_logit(me, "tid in base = %d\n", base->tid);
474cb5caa98Sdjl 			_nscd_logit(me, "number of free nsw_state = %d\n",
475cb5caa98Sdjl 			    ctrl_p->free);
476cb5caa98Sdjl 			_nscd_logit(me, "number of nsw state allocated = %d\n",
477cb5caa98Sdjl 			    ctrl_p->allocated);
478cb5caa98Sdjl 			_nscd_logit(me, "first nsw state on list = %p\n",
479cb5caa98Sdjl 			    ctrl_p->first);
480cb5caa98Sdjl 			_nscd_logit(me, "number of waiter = %d\n",
481cb5caa98Sdjl 			    ctrl_p->waiter);
482bf1e3beeSmichen 
483cb5caa98Sdjl 		}
484cb5caa98Sdjl 	}
485cb5caa98Sdjl 
486cb5caa98Sdjl 	if (ctrl_p->first == NULL && ctrl_p->allocated == ctrl_p->max)
487cb5caa98Sdjl 		wait_cond = 1;
488cb5caa98Sdjl 	else if (thread_only && base->used_by_thr && base->tid != *tid)
489cb5caa98Sdjl 		wait_cond = 1;
490cb5caa98Sdjl 
491cb5caa98Sdjl 	if (wait_cond) {
492cb5caa98Sdjl 
493cb5caa98Sdjl 		ctrl_p->waiter++;
494cb5caa98Sdjl 
495cb5caa98Sdjl 		while (wait_cond) {
496cb5caa98Sdjl 			if (!thread_only)
497cb5caa98Sdjl 				_NSCD_LOG(NSCD_LOG_NSW_STATE,
498cb5caa98Sdjl 				    NSCD_LOG_LEVEL_DEBUG)
499cb5caa98Sdjl 				(me, "waiting for nsw state signal\n");
500cb5caa98Sdjl 			else
501cb5caa98Sdjl 				_NSCD_LOG(NSCD_LOG_NSW_STATE,
502cb5caa98Sdjl 				    NSCD_LOG_LEVEL_DEBUG)
503cb5caa98Sdjl 				(me, "waiting for per thread "
504cb5caa98Sdjl 				    "nsw state signal\n");
505cb5caa98Sdjl 
506cb5caa98Sdjl 			if (thread_only) {
507cb5caa98Sdjl 				_nscd_cond_wait((nscd_acc_data_t *)base,
508cb5caa98Sdjl 				    &base->thr_cond);
509cb5caa98Sdjl 
510cb5caa98Sdjl 				if (base->used_by_thr == 0 &&
511cb5caa98Sdjl 				    ctrl_p->first != NULL)
512cb5caa98Sdjl 					wait_cond = 0;
513cb5caa98Sdjl 			} else {
514cb5caa98Sdjl 				_nscd_cond_wait((nscd_acc_data_t *)base, NULL);
515cb5caa98Sdjl 
516cb5caa98Sdjl 				if (ctrl_p->first != NULL)
517cb5caa98Sdjl 					wait_cond = 0;
518cb5caa98Sdjl 			}
519cb5caa98Sdjl 
520cb5caa98Sdjl 			if (!thread_only)
521cb5caa98Sdjl 				_NSCD_LOG(NSCD_LOG_NSW_STATE,
522cb5caa98Sdjl 				    NSCD_LOG_LEVEL_DEBUG)
523cb5caa98Sdjl 				(me, "woke from cond wait ...wait_cond = %d\n",
524cb5caa98Sdjl 				    wait_cond);
525cb5caa98Sdjl 			else
526cb5caa98Sdjl 
527cb5caa98Sdjl 				_NSCD_LOG(NSCD_LOG_NSW_STATE,
528cb5caa98Sdjl 				    NSCD_LOG_LEVEL_DEBUG)
529cb5caa98Sdjl 				(me, "woke from cond wait (per thread) "
530cb5caa98Sdjl 				    "...wait_cond = %d\n", wait_cond);
531cb5caa98Sdjl 
532cb5caa98Sdjl 		}
533cb5caa98Sdjl 
534cb5caa98Sdjl 		ctrl_p->waiter--;
535cb5caa98Sdjl 	}
536cb5caa98Sdjl 
537cb5caa98Sdjl 	if (ctrl_p->first == NULL) {
538cb5caa98Sdjl 		int	geti;
539cb5caa98Sdjl 
540cb5caa98Sdjl 		/*
541cb5caa98Sdjl 		 * for lookup calls from the compat backend
542cb5caa98Sdjl 		 * uses the switch policy for passwd_compat
543cb5caa98Sdjl 		 * or group_compat
544cb5caa98Sdjl 		 */
545cb5caa98Sdjl 		if (params->compati != -1)
546cb5caa98Sdjl 			geti = params->compati;
547cb5caa98Sdjl 		else
548cb5caa98Sdjl 			geti = params->dbi;
549cb5caa98Sdjl 
550cb5caa98Sdjl 		params->nswcfg = (nscd_nsw_config_t **)_nscd_get(
551cb5caa98Sdjl 		    (nscd_acc_data_t *)nscd_nsw_config[geti]);
552cb5caa98Sdjl 		_NSCD_LOG(NSCD_LOG_NSW_STATE, NSCD_LOG_LEVEL_DEBUG)
553cb5caa98Sdjl 		(me, "got a nsw config %p for index %d\n",
554cb5caa98Sdjl 		    params->nswcfg, geti);
555cb5caa98Sdjl 
556cb5caa98Sdjl 		ctrl_p->first = _nscd_create_nsw_state(params);
557cb5caa98Sdjl 		if (ctrl_p->first != NULL) {
558cb5caa98Sdjl 			ctrl_p->first->base = base;
559cb5caa98Sdjl 
560cb5caa98Sdjl 			if (tid == NULL) {
561cb5caa98Sdjl 				_NSCD_LOG(NSCD_LOG_NSW_STATE,
562cb5caa98Sdjl 				    NSCD_LOG_LEVEL_DEBUG)
563cb5caa98Sdjl 				(me, "got a new nsw_state %p\n", ctrl_p->first);
564cb5caa98Sdjl 			} else {
565cb5caa98Sdjl 				_NSCD_LOG(NSCD_LOG_NSW_STATE,
566cb5caa98Sdjl 				    NSCD_LOG_LEVEL_DEBUG)
567cb5caa98Sdjl 				(me, "got a new per thread nsw_state %p\n",
568cb5caa98Sdjl 				    ctrl_p->first);
569cb5caa98Sdjl 			}
570cb5caa98Sdjl 			ctrl_p->allocated++;
571cb5caa98Sdjl 			ctrl_p->free++;
572cb5caa98Sdjl 		} else {
573cb5caa98Sdjl 			_NSCD_LOG(NSCD_LOG_NSW_STATE, NSCD_LOG_LEVEL_ERROR)
574cb5caa98Sdjl 				(me, "error: unable to obtain a nsw state\n");
575cb5caa98Sdjl 			_nscd_mutex_unlock((nscd_acc_data_t *)base);
576cb5caa98Sdjl 			return (NSCD_CREATE_NSW_STATE_FAILED);
577cb5caa98Sdjl 		}
578cb5caa98Sdjl 	}
579cb5caa98Sdjl 
580cb5caa98Sdjl 	ret = ctrl_p->first;
581bf1e3beeSmichen 	if (ret->recheck_be == nscd_true)
582bf1e3beeSmichen 		check_be_array(ret);
583cb5caa98Sdjl 	ctrl_p->first = ret->next;
584cb5caa98Sdjl 	ret->next = NULL;
585cb5caa98Sdjl 	ctrl_p->free--;
586cb5caa98Sdjl 	if (thread_only) {
587cb5caa98Sdjl 		base->tid = *tid;
588cb5caa98Sdjl 		base->used_by_thr = 1;
589cb5caa98Sdjl 
590cb5caa98Sdjl 		_NSCD_LOG_IF(NSCD_LOG_NSW_STATE, NSCD_LOG_LEVEL_DEBUG) {
591cb5caa98Sdjl 			_nscd_logit(me, "\t\t\tgot a per thread nsw "
592cb5caa98Sdjl 			    "state %p: \n", ret);
593cb5caa98Sdjl 			_nscd_logit(me, "tid = %d\n", *tid);
594cb5caa98Sdjl 			_nscd_logit(me, "tid in base = %d\n", base->tid);
595cb5caa98Sdjl 			_nscd_logit(me, "number of free nsw_state = %d\n",
596cb5caa98Sdjl 			    ctrl_p->free);
597cb5caa98Sdjl 			_nscd_logit(me, "number od nsw state allocated = %d\n",
598cb5caa98Sdjl 			    ctrl_p->allocated);
599cb5caa98Sdjl 			_nscd_logit(me, "first nsw state on list = %p\n",
600cb5caa98Sdjl 			    ctrl_p->first);
601cb5caa98Sdjl 			_nscd_logit(me, "number of waiter = %d\n",
602cb5caa98Sdjl 			    ctrl_p->waiter);
603cb5caa98Sdjl 		}
604cb5caa98Sdjl 	}
605cb5caa98Sdjl 	else
606cb5caa98Sdjl 		_NSCD_LOG(NSCD_LOG_NSW_STATE, NSCD_LOG_LEVEL_DEBUG)
607cb5caa98Sdjl 		(me, "got old nsw state %p\n", ret);
608cb5caa98Sdjl 
609cb5caa98Sdjl 	_nscd_mutex_unlock((nscd_acc_data_t *)base);
610cb5caa98Sdjl 
611cb5caa98Sdjl 	rootp->s = (struct nss_db_state *)ret;
612cb5caa98Sdjl 
613cb5caa98Sdjl 	return (NSCD_SUCCESS);
614cb5caa98Sdjl }
615cb5caa98Sdjl 
616cb5caa98Sdjl nscd_rc_t
617cb5caa98Sdjl _nscd_get_nsw_state(
618cb5caa98Sdjl 	nss_db_root_t		*rootp,
619cb5caa98Sdjl 	nscd_nsw_params_t	*params)
620cb5caa98Sdjl {
621cb5caa98Sdjl 	return (_get_nsw_state_int(rootp, params, NULL));
622cb5caa98Sdjl }
623cb5caa98Sdjl 
624cb5caa98Sdjl nscd_rc_t
625cb5caa98Sdjl _nscd_get_nsw_state_thread(
626cb5caa98Sdjl 	nss_db_root_t		*rootp,
627cb5caa98Sdjl 	nscd_nsw_params_t	*params)
628cb5caa98Sdjl {
629cb5caa98Sdjl 	thread_t	tid = thr_self();
630cb5caa98Sdjl 	return (_get_nsw_state_int(rootp, params, &tid));
631cb5caa98Sdjl }
632cb5caa98Sdjl 
633cb5caa98Sdjl 
634cb5caa98Sdjl static void
635cb5caa98Sdjl _put_nsw_state_int(
636cb5caa98Sdjl 	nscd_nsw_state_t	*s,
637cb5caa98Sdjl 	thread_t		*tid)
638cb5caa98Sdjl {
639cb5caa98Sdjl 
640cb5caa98Sdjl 	nscd_nsw_state_base_t	*base;
641cb5caa98Sdjl 	nscd_state_ctrl_t	*ctrl_p;
642cb5caa98Sdjl 	int			thread_only = 0;
643cb5caa98Sdjl 	char			*me = "_put_nsw_state_int";
644cb5caa98Sdjl 
645cb5caa98Sdjl 	_NSCD_LOG(NSCD_LOG_NSW_STATE, NSCD_LOG_LEVEL_DEBUG)
646cb5caa98Sdjl 	(me, "put back a nsw state\n");
647cb5caa98Sdjl 
648cb5caa98Sdjl 	if (s == NULL) {
649cb5caa98Sdjl 		_NSCD_LOG(NSCD_LOG_NSW_STATE, NSCD_LOG_LEVEL_DEBUG)
650cb5caa98Sdjl 		(me, "nsw state is NULL, nothing to put back\n");
651cb5caa98Sdjl 		return;
652cb5caa98Sdjl 	}
653cb5caa98Sdjl 
654cb5caa98Sdjl 	/*
655cb5caa98Sdjl 	 * no need to put back if the nsw state is not on any base
656cb5caa98Sdjl 	 * but need to free the resources used
657cb5caa98Sdjl 	 */
658cb5caa98Sdjl 	if ((*s->nsw_cfg_p)->nobase  == 1) {
659cb5caa98Sdjl 		_NSCD_LOG(NSCD_LOG_NSW_STATE, NSCD_LOG_LEVEL_DEBUG)
660cb5caa98Sdjl 		(me, "no base nsw state, freeing resources ...\n");
661cb5caa98Sdjl 
662cb5caa98Sdjl 		_nscd_free_nsw_state(s);
663cb5caa98Sdjl 		return;
664cb5caa98Sdjl 	}
665cb5caa98Sdjl 
666cb5caa98Sdjl 	if (tid != NULL)
667cb5caa98Sdjl 		thread_only = 1;
668cb5caa98Sdjl 
669cb5caa98Sdjl 	base = s->base;
670cb5caa98Sdjl 
671cb5caa98Sdjl 	if (_nscd_mutex_lock((nscd_acc_data_t *)base) == NULL) {
672cb5caa98Sdjl 		/* base has been freed, free this db state */
673cb5caa98Sdjl 		_NSCD_LOG(NSCD_LOG_NSW_STATE, NSCD_LOG_LEVEL_DEBUG)
674cb5caa98Sdjl 		(me, "nsw state base has been freed, freeing %p\n", s);
675cb5caa98Sdjl 		_nscd_free_nsw_state(s);
676cb5caa98Sdjl 		return;
677cb5caa98Sdjl 	}
678cb5caa98Sdjl 
679cb5caa98Sdjl 	if (thread_only)
680cb5caa98Sdjl 		ctrl_p = &base->nsw_state_thr;
681cb5caa98Sdjl 	else
682cb5caa98Sdjl 		ctrl_p = &base->nsw_state;
683cb5caa98Sdjl 
684cb5caa98Sdjl 	_NSCD_LOG_IF(NSCD_LOG_NSW_STATE, NSCD_LOG_LEVEL_DEBUG) {
685cb5caa98Sdjl 		_nscd_logit(me, "before returning the nsw state: \n");
686cb5caa98Sdjl 		_nscd_logit(me, "tid = %d\n", (tid == NULL) ? -1 : *tid);
687cb5caa98Sdjl 		_nscd_logit(me, "tid in base = %d\n", base->tid);
688cb5caa98Sdjl 		_nscd_logit(me, "number of free nsw_state = %d\n",
689cb5caa98Sdjl 		    ctrl_p->free);
690cb5caa98Sdjl 		_nscd_logit(me, "number od nsw state allocated = %d\n",
691cb5caa98Sdjl 		    ctrl_p->allocated);
692cb5caa98Sdjl 		_nscd_logit(me, "first nsw state on list = %p\n",
693cb5caa98Sdjl 		    ctrl_p->first);
694bf1e3beeSmichen 		_nscd_logit(me, "number of waiter = %d\n", ctrl_p->waiter);
695cb5caa98Sdjl 	}
696cb5caa98Sdjl 
697cb5caa98Sdjl 	if (ctrl_p->first != NULL) {
698cb5caa98Sdjl 		s->next = ctrl_p->first;
699cb5caa98Sdjl 		ctrl_p->first = s;
700cb5caa98Sdjl 	} else {
701cb5caa98Sdjl 		ctrl_p->first = s;
702cb5caa98Sdjl 		s->next = NULL;
703cb5caa98Sdjl 	}
704cb5caa98Sdjl 	ctrl_p->free++;
705cb5caa98Sdjl 
706cb5caa98Sdjl 	_NSCD_LOG(NSCD_LOG_NSW_STATE, NSCD_LOG_LEVEL_DEBUG)
707cb5caa98Sdjl 	(me, "signaling waiter thread_only = %d..\n", thread_only);
708cb5caa98Sdjl 
709cb5caa98Sdjl 	if (thread_only && ctrl_p->free == ctrl_p->allocated) {
710cb5caa98Sdjl 		assert(ctrl_p->first != NULL);
711cb5caa98Sdjl 		base->used_by_thr = 0;
712cb5caa98Sdjl 		if (ctrl_p->waiter > 0) {
713cb5caa98Sdjl 			(void) cond_signal(&base->thr_cond);
714cb5caa98Sdjl 		}
715cb5caa98Sdjl 	}
716cb5caa98Sdjl 
717cb5caa98Sdjl 	if (!thread_only && ctrl_p->waiter > 0) {
718cb5caa98Sdjl 
719cb5caa98Sdjl 		_nscd_cond_signal((nscd_acc_data_t *)base);
720cb5caa98Sdjl 	}
721cb5caa98Sdjl 
722cb5caa98Sdjl 	_NSCD_LOG_IF(NSCD_LOG_NSW_STATE, NSCD_LOG_LEVEL_DEBUG) {
723cb5caa98Sdjl 		_nscd_logit(me, "after the nsw state is returned: \n");
724cb5caa98Sdjl 		_nscd_logit(me, "tid = %d\n", (tid == NULL) ? -1 : *tid);
725cb5caa98Sdjl 		_nscd_logit(me, "tid in base = %d\n", base->tid);
726cb5caa98Sdjl 		_nscd_logit(me, "number of free nsw_state = %d\n",
727cb5caa98Sdjl 		    ctrl_p->free);
728cb5caa98Sdjl 		_nscd_logit(me, "number od nsw state allocated = %d\n",
729cb5caa98Sdjl 		    ctrl_p->allocated);
730cb5caa98Sdjl 		_nscd_logit(me, "first nsw state on list = %p\n",
731cb5caa98Sdjl 		    ctrl_p->first);
732bf1e3beeSmichen 		_nscd_logit(me, "tnumber of waiter = %d\n", ctrl_p->waiter);
733cb5caa98Sdjl 	}
734cb5caa98Sdjl 
735cb5caa98Sdjl 	_NSCD_LOG(NSCD_LOG_NSW_STATE, NSCD_LOG_LEVEL_DEBUG)
736cb5caa98Sdjl 	(me, "done putting back nsw state %p, thread_only = %d\n",
737cb5caa98Sdjl 	    s, thread_only);
738cb5caa98Sdjl 
739cb5caa98Sdjl 	_nscd_mutex_unlock((nscd_acc_data_t *)base);
740cb5caa98Sdjl 
741cb5caa98Sdjl }
742cb5caa98Sdjl 
743cb5caa98Sdjl void
744cb5caa98Sdjl _nscd_put_nsw_state(
745cb5caa98Sdjl 	nscd_nsw_state_t	*s)
746cb5caa98Sdjl {
747cb5caa98Sdjl 	_put_nsw_state_int(s, NULL);
748cb5caa98Sdjl }
749cb5caa98Sdjl 
750cb5caa98Sdjl void
751cb5caa98Sdjl _nscd_put_nsw_state_thread(
752cb5caa98Sdjl 	nscd_nsw_state_t	*s)
753cb5caa98Sdjl {
754cb5caa98Sdjl 	thread_t		tid = thr_self();
755cb5caa98Sdjl 	_put_nsw_state_int(s, &tid);
756cb5caa98Sdjl }
757cb5caa98Sdjl 
758cb5caa98Sdjl nscd_rc_t
759cb5caa98Sdjl _nscd_init_nsw_state_base(
760cb5caa98Sdjl 	int			dbi,
761ad0e80f7Smichen 	int			compat_basei,
762cb5caa98Sdjl 	int			lock)
763cb5caa98Sdjl {
764ad0e80f7Smichen 	int			cfgdbi;
765cb5caa98Sdjl 	nscd_nsw_state_base_t	*base = NULL;
766cb5caa98Sdjl 	char			*me = "_nscd_init_nsw_state_base";
767cb5caa98Sdjl 
768cb5caa98Sdjl 	if (lock)
769cb5caa98Sdjl 		(void) rw_rdlock(&nscd_nsw_state_base_lock);
770cb5caa98Sdjl 
771cb5caa98Sdjl 	base = (nscd_nsw_state_base_t *)_nscd_alloc(
772cb5caa98Sdjl 	    NSCD_DATA_NSW_STATE_BASE,
773cb5caa98Sdjl 	    sizeof (nscd_nsw_state_base_t),
774cb5caa98Sdjl 	    _nscd_free_nsw_state_base,
775cb5caa98Sdjl 	    NSCD_ALLOC_MUTEX | NSCD_ALLOC_COND);
776cb5caa98Sdjl 
777cb5caa98Sdjl 	if (base == NULL) {
778cb5caa98Sdjl 		_NSCD_LOG(NSCD_LOG_NSW_STATE | NSCD_LOG_CONFIG,
779cb5caa98Sdjl 		    NSCD_LOG_LEVEL_ERROR)
780cb5caa98Sdjl 		(me, "not able to allocate a nsw state base\n");
781cb5caa98Sdjl 		if (lock)
782cb5caa98Sdjl 			(void) rw_unlock(&nscd_nsw_state_base_lock);
783cb5caa98Sdjl 		return (NSCD_NO_MEMORY);
784cb5caa98Sdjl 	}
785bf1e3beeSmichen 	_NSCD_LOG(NSCD_LOG_NSW_STATE | NSCD_LOG_CONFIG, NSCD_LOG_LEVEL_DEBUG)
786cb5caa98Sdjl 		(me, "nsw state base %p allocated\n", base);
787cb5caa98Sdjl 
788cb5caa98Sdjl 	/*
789cb5caa98Sdjl 	 * initialize and activate the new nss_nsw_state base
790cb5caa98Sdjl 	 */
791cb5caa98Sdjl 	base->dbi = dbi;
792ad0e80f7Smichen 	if (compat_basei != -1)
793ad0e80f7Smichen 		cfgdbi = compat_basei;
794ad0e80f7Smichen 	else
795ad0e80f7Smichen 		cfgdbi = dbi;
796ad0e80f7Smichen 
797ad0e80f7Smichen 	base->nsw_state.max = NSCD_SW_CFG(cfgdbi).max_nsw_state_per_db;
798ad0e80f7Smichen 	base->nsw_state_thr.max = NSCD_SW_CFG(cfgdbi).max_nsw_state_per_thread;
799cb5caa98Sdjl 
800cb5caa98Sdjl 	nscd_nsw_state_base[dbi] = (nscd_nsw_state_base_t *)_nscd_set(
801cb5caa98Sdjl 	    (nscd_acc_data_t *)nscd_nsw_state_base[dbi],
802cb5caa98Sdjl 	    (nscd_acc_data_t *)base);
803cb5caa98Sdjl 
804cb5caa98Sdjl 	if (lock)
805cb5caa98Sdjl 		(void) rw_unlock(&nscd_nsw_state_base_lock);
806cb5caa98Sdjl 
807cb5caa98Sdjl 	return (NSCD_SUCCESS);
808cb5caa98Sdjl }
809cb5caa98Sdjl 
810cb5caa98Sdjl nscd_rc_t
811cb5caa98Sdjl _nscd_init_all_nsw_state_base()
812cb5caa98Sdjl {
813cb5caa98Sdjl 	int			i;
814cb5caa98Sdjl 	nscd_rc_t		rc;
815cb5caa98Sdjl 	char			*me = "_nscd_init_all_nsw_state_base";
816cb5caa98Sdjl 
817cb5caa98Sdjl 	(void) rw_rdlock(&nscd_nsw_state_base_lock);
818cb5caa98Sdjl 
819cb5caa98Sdjl 	for (i = 0; i < NSCD_NUM_DB; i++) {
820cb5caa98Sdjl 
821ad0e80f7Smichen 		rc = _nscd_init_nsw_state_base(i, -1, 0);
822cb5caa98Sdjl 
823cb5caa98Sdjl 		if (rc != NSCD_SUCCESS) {
824cb5caa98Sdjl 			_NSCD_LOG(NSCD_LOG_NSW_STATE | NSCD_LOG_CONFIG,
825cb5caa98Sdjl 			    NSCD_LOG_LEVEL_ERROR)
826cb5caa98Sdjl 			(me, "not able to initialize a nsw db state "
827cb5caa98Sdjl 			    "base (%d)\n", i);
828cb5caa98Sdjl 
829cb5caa98Sdjl 			(void) rw_unlock(&nscd_nsw_state_base_lock);
830cb5caa98Sdjl 			return (rc);
831cb5caa98Sdjl 		}
832cb5caa98Sdjl 	}
833bf1e3beeSmichen 	_NSCD_LOG(NSCD_LOG_NSW_STATE | NSCD_LOG_CONFIG, NSCD_LOG_LEVEL_DEBUG)
834cb5caa98Sdjl 	(me, "all nsw state base initialized\n");
835cb5caa98Sdjl 
836cb5caa98Sdjl 	(void) rw_unlock(&nscd_nsw_state_base_lock);
837cb5caa98Sdjl 
838cb5caa98Sdjl 	return (NSCD_SUCCESS);
839cb5caa98Sdjl }
840cb5caa98Sdjl 
841cb5caa98Sdjl nscd_rc_t
842cb5caa98Sdjl _nscd_alloc_nsw_state_base()
843cb5caa98Sdjl {
844cb5caa98Sdjl 
845cb5caa98Sdjl 	(void) rw_rdlock(&nscd_nsw_state_base_lock);
846cb5caa98Sdjl 
847cb5caa98Sdjl 	nscd_nsw_state_base = calloc(NSCD_NUM_DB,
848cb5caa98Sdjl 	    sizeof (nscd_nsw_state_base_t *));
849cb5caa98Sdjl 	if (nscd_nsw_state_base == NULL) {
850cb5caa98Sdjl 		(void) rw_unlock(&nscd_nsw_state_base_lock);
851cb5caa98Sdjl 		return (NSCD_NO_MEMORY);
852cb5caa98Sdjl 	}
853cb5caa98Sdjl 
854cb5caa98Sdjl 	(void) rw_rdlock(&nscd_nsw_state_base_lock);
855cb5caa98Sdjl 
856cb5caa98Sdjl 	return (NSCD_SUCCESS);
857cb5caa98Sdjl }
858