xref: /titanic_44/usr/src/cmd/nscd/nscd_getentctx.c (revision a4aeef46cda1835da2b19f8f62b4526de6521e6c)
1 /*
2  * CDDL HEADER START
3  *
4  * The contents of this file are subject to the terms of the
5  * Common Development and Distribution License (the "License").
6  * You may not use this file except in compliance with the License.
7  *
8  * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
9  * or http://www.opensolaris.org/os/licensing.
10  * See the License for the specific language governing permissions
11  * and limitations under the License.
12  *
13  * When distributing Covered Code, include this CDDL HEADER in each
14  * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
15  * If applicable, add the following below this CDDL HEADER, with the
16  * fields enclosed by brackets "[]" replaced with your own identifying
17  * information: Portions Copyright [yyyy] [name of copyright owner]
18  *
19  * CDDL HEADER END
20  */
21 /*
22  * Copyright 2009 Sun Microsystems, Inc.  All rights reserved.
23  * Use is subject to license terms.
24  */
25 
26 #include <stdlib.h>
27 #include <assert.h>
28 #include <string.h>
29 #include <errno.h>
30 #include <fcntl.h>
31 #include "nscd_db.h"
32 #include "nscd_log.h"
33 #include "nscd_switch.h"
34 #include "nscd_door.h"
35 
36 extern int		_whoami;
37 static mutex_t		getent_monitor_mutex = DEFAULTMUTEX;
38 static int		getent_monitor_started = 0;
39 
40 static rwlock_t		getent_ctxDB_rwlock = DEFAULTRWLOCK;
41 static nscd_db_t	*getent_ctxDB = NULL;
42 
43 /*
44  * internal structure representing a nscd getent context
45  */
46 typedef struct nscd_getent_ctx {
47 	int			to_delete; /* this ctx no longer valid */
48 	nscd_getent_context_t	*ptr;
49 	nscd_cookie_num_t	cookie_num;
50 } nscd_getent_ctx_t;
51 
52 /*
53  * nscd_getent_context_t list for each nss database. Protected
54  * by the readers/writer lock nscd_getent_ctx_lock.
55  */
56 nscd_getent_ctx_base_t **nscd_getent_ctx_base;
57 static rwlock_t nscd_getent_ctx_base_lock = DEFAULTRWLOCK;
58 
59 extern nscd_db_entry_t *_nscd_walk_db(nscd_db_t *db, void **cookie);
60 
61 static nscd_rc_t _nscd_init_getent_ctx_monitor();
62 
63 /*
64  * FUNCTION: _nscd_create_getent_ctxDB
65  *
66  * Create the internal getent context database to keep track of the
67  * getent contexts currently being used.
68  */
69 nscd_db_t *
70 _nscd_create_getent_ctxDB()
71 {
72 
73 	nscd_db_t	*ret;
74 
75 	(void) rw_wrlock(&getent_ctxDB_rwlock);
76 
77 	if (getent_ctxDB != NULL) {
78 		(void) rw_unlock(&getent_ctxDB_rwlock);
79 		return (getent_ctxDB);
80 	}
81 
82 	ret = _nscd_alloc_db(NSCD_DB_SIZE_LARGE);
83 
84 	if (ret != NULL)
85 		getent_ctxDB = ret;
86 
87 	(void) rw_unlock(&getent_ctxDB_rwlock);
88 
89 	return (ret);
90 }
91 
92 /*
93  * FUNCTION: _nscd_add_getent_ctx
94  *
95  * Add a getent context to the internal context database.
96  */
97 static nscd_rc_t
98 _nscd_add_getent_ctx(
99 	nscd_getent_context_t	*ptr,
100 	nscd_cookie_num_t	cookie_num)
101 {
102 	int			size;
103 	char			buf[32];
104 	nscd_db_entry_t		*db_entry;
105 	nscd_getent_ctx_t	*gnctx;
106 
107 	if (ptr == NULL)
108 		return (NSCD_INVALID_ARGUMENT);
109 
110 	(void) snprintf(buf, sizeof (buf), "%lld", cookie_num);
111 
112 	size = sizeof (*gnctx);
113 
114 	db_entry = _nscd_alloc_db_entry(NSCD_DATA_CTX_ADDR,
115 	    (const char *)buf, size, 1, 1);
116 	if (db_entry == NULL)
117 		return (NSCD_NO_MEMORY);
118 
119 	gnctx = (nscd_getent_ctx_t *)*(db_entry->data_array);
120 	gnctx->ptr = ptr;
121 	gnctx->cookie_num = cookie_num;
122 
123 	(void) rw_wrlock(&getent_ctxDB_rwlock);
124 	(void) _nscd_add_db_entry(getent_ctxDB, buf, db_entry,
125 	    NSCD_ADD_DB_ENTRY_FIRST);
126 	(void) rw_unlock(&getent_ctxDB_rwlock);
127 
128 	return (NSCD_SUCCESS);
129 }
130 
131 /*
132  * FUNCTION: _nscd_is_getent_ctx
133  *
134  * Check to see if a getent context can be found in the internal
135  * getent context database.
136  */
137 nscd_getent_context_t *
138 _nscd_is_getent_ctx(
139 	nscd_cookie_num_t	cookie_num)
140 {
141 	char			ptrstr[32];
142 	const nscd_db_entry_t	*db_entry;
143 	nscd_getent_context_t	*ret = NULL;
144 	char			*me = "_nscd_is_getent_ctx";
145 
146 	(void) snprintf(ptrstr, sizeof (ptrstr), "%lld", cookie_num);
147 
148 	(void) rw_rdlock(&getent_ctxDB_rwlock);
149 
150 	db_entry = _nscd_get_db_entry(getent_ctxDB, NSCD_DATA_CTX_ADDR,
151 	    (const char *)ptrstr, NSCD_GET_FIRST_DB_ENTRY, 0);
152 
153 	if (db_entry != NULL) {
154 		nscd_getent_ctx_t *gnctx;
155 
156 		gnctx = (nscd_getent_ctx_t *)*(db_entry->data_array);
157 		_NSCD_LOG(NSCD_LOG_GETENT_CTX, NSCD_LOG_LEVEL_DEBUG)
158 		(me, "getent context %p, cookie# %lld, to_delete %d\n",
159 		    gnctx->ptr, gnctx->cookie_num, gnctx->to_delete);
160 
161 		/*
162 		 * If the ctx is not to be deleted and the cookie numbers
163 		 * match, return the ctx if not aborted and not in use.
164 		 * Otherwise return NULL.
165 		 */
166 		if (gnctx->to_delete == 0 && gnctx->cookie_num == cookie_num) {
167 			ret = gnctx->ptr;
168 			(void) mutex_lock(&gnctx->ptr->getent_mutex);
169 			if (ret->aborted == 1 || ret->in_use == 1)
170 				ret = NULL;
171 			else
172 				ret->in_use = 1;
173 			(void) mutex_unlock(&gnctx->ptr->getent_mutex);
174 		}
175 	}
176 
177 	(void) rw_unlock(&getent_ctxDB_rwlock);
178 
179 	return (ret);
180 }
181 
182 int
183 _nscd_is_getent_ctx_in_use(
184 	nscd_getent_context_t	*ctx)
185 {
186 	int	in_use;
187 	char	*me = "_nscd_getent_ctx_in_use";
188 
189 	(void) mutex_lock(&ctx->getent_mutex);
190 
191 	_NSCD_LOG(NSCD_LOG_GETENT_CTX, NSCD_LOG_LEVEL_DEBUG)
192 	(me, "in_use = %d, ctx->thr_id = %d, thread id = %d\n",
193 	    ctx->in_use, ctx->thr_id, thr_self());
194 
195 	in_use = ctx->in_use;
196 	if (in_use == 1 && ctx->thr_id == thr_self())
197 		in_use = 0;
198 	(void) mutex_unlock(&ctx->getent_mutex);
199 	return (in_use);
200 }
201 
202 /*
203  * FUNCTION: _nscd_free_ctx_if_aborted
204  *
205  * Check to see if the getent session associated with a getent context had
206  * been aborted. If so, return the getent context back to the pool.
207  */
208 void
209 _nscd_free_ctx_if_aborted(
210 	nscd_getent_context_t	*ctx)
211 {
212 	int	aborted;
213 	char	*me = "_nscd_free_ctx_if_aborted";
214 
215 	(void) mutex_lock(&ctx->getent_mutex);
216 
217 	_NSCD_LOG(NSCD_LOG_GETENT_CTX, NSCD_LOG_LEVEL_DEBUG)
218 	(me, "in_use = %d, aborted = %d\n", ctx->in_use, ctx->aborted);
219 
220 	if (ctx->in_use != 1) {
221 		(void) mutex_unlock(&ctx->getent_mutex);
222 		return;
223 	}
224 	aborted = ctx->aborted;
225 	ctx->in_use = 0;
226 	(void) mutex_unlock(&ctx->getent_mutex);
227 
228 	if (aborted == 1) {
229 		_NSCD_LOG(NSCD_LOG_GETENT_CTX, NSCD_LOG_LEVEL_DEBUG)
230 		(me, "getent session aborted, return the getent context\n");
231 		_nscd_put_getent_ctx(ctx);
232 	}
233 }
234 
235 /*
236  * FUNCTION: _nscd_del_getent_ctx
237  *
238  * Delete a getent context from the internal getent context database.
239  */
240 static void
241 _nscd_del_getent_ctx(
242 	nscd_getent_context_t	*ptr,
243 	nscd_cookie_num_t	cookie_num)
244 {
245 	char			ptrstr[32];
246 	nscd_getent_ctx_t	*gnctx;
247 	const nscd_db_entry_t	*db_entry;
248 
249 	if (ptr == NULL)
250 		return;
251 
252 	(void) snprintf(ptrstr, sizeof (ptrstr), "%lld", cookie_num);
253 
254 	(void) rw_rdlock(&getent_ctxDB_rwlock);
255 	/*
256 	 * first find the db entry and make sure the
257 	 * sequence number matched, then delete it from
258 	 * the database.
259 	 */
260 	db_entry = _nscd_get_db_entry(getent_ctxDB,
261 	    NSCD_DATA_CTX_ADDR,
262 	    (const char *)ptrstr,
263 	    NSCD_GET_FIRST_DB_ENTRY, 0);
264 	if (db_entry != NULL) {
265 		gnctx = (nscd_getent_ctx_t *)*(db_entry->data_array);
266 		if (gnctx->ptr == ptr && gnctx->cookie_num  == cookie_num) {
267 
268 			(void) rw_unlock(&getent_ctxDB_rwlock);
269 			(void) rw_wrlock(&getent_ctxDB_rwlock);
270 
271 			(void) _nscd_delete_db_entry(getent_ctxDB,
272 			    NSCD_DATA_CTX_ADDR,
273 			    (const char *)ptrstr,
274 			    NSCD_DEL_FIRST_DB_ENTRY, 0);
275 		}
276 	}
277 	(void) rw_unlock(&getent_ctxDB_rwlock);
278 }
279 
280 static void
281 _nscd_free_getent_ctx(
282 	nscd_getent_context_t	*gnctx)
283 {
284 
285 	char			*me = "_nscd_free_getent_ctx";
286 
287 	_NSCD_LOG(NSCD_LOG_GETENT_CTX, NSCD_LOG_LEVEL_DEBUG)
288 	(me, "getent context %p\n", gnctx);
289 
290 	_nscd_put_nsw_state(gnctx->nsw_state);
291 
292 	if (gnctx->base != NULL) {
293 		/* remove reference to the getent context base */
294 		_nscd_release((nscd_acc_data_t *)gnctx->base);
295 		gnctx->base = NULL;
296 	}
297 
298 	_nscd_del_getent_ctx(gnctx, gnctx->cookie_num);
299 	free(gnctx);
300 }
301 
302 
303 static void
304 _nscd_free_getent_ctx_base(
305 	nscd_acc_data_t		*data)
306 {
307 	nscd_getent_ctx_base_t	*base = (nscd_getent_ctx_base_t *)data;
308 	nscd_getent_context_t	*c, *tc;
309 	char			*me = "_nscd_free_getent_ctx_base";
310 
311 	_NSCD_LOG(NSCD_LOG_GETENT_CTX | NSCD_LOG_CONFIG, NSCD_LOG_LEVEL_DEBUG)
312 	(me, "getent context base %p\n", base);
313 
314 	if (base == NULL)
315 		return;
316 
317 	c = base->first;
318 	while (c != NULL) {
319 		tc = c->next;
320 		_nscd_free_getent_ctx(c);
321 		c = tc;
322 	}
323 }
324 
325 void
326 _nscd_free_all_getent_ctx_base()
327 {
328 	nscd_getent_ctx_base_t	*base;
329 	int			i;
330 	char			*me = "_nscd_free_all_getent_ctx_base";
331 
332 	_NSCD_LOG(NSCD_LOG_GETENT_CTX | NSCD_LOG_CONFIG, NSCD_LOG_LEVEL_DEBUG)
333 	(me, "entering ..\n");
334 
335 	(void) rw_wrlock(&nscd_getent_ctx_base_lock);
336 
337 	for (i = 0; i < NSCD_NUM_DB; i++) {
338 
339 		base = nscd_getent_ctx_base[i];
340 		if (base == NULL)
341 			continue;
342 
343 		nscd_getent_ctx_base[i] = (nscd_getent_ctx_base_t *)
344 		    _nscd_set((nscd_acc_data_t *)base, NULL);
345 	}
346 	(void) rw_unlock(&nscd_getent_ctx_base_lock);
347 }
348 
349 static nscd_getent_context_t *
350 _nscd_create_getent_ctx(
351 	nscd_nsw_params_t	*params)
352 {
353 	nscd_getent_context_t	*gnctx;
354 	nss_db_root_t		db_root;
355 	char			*me = "_nscd_create_getent_ctx";
356 
357 	gnctx = calloc(1, sizeof (nscd_getent_context_t));
358 	if (gnctx == NULL)
359 		return (NULL);
360 	else {
361 		_NSCD_LOG(NSCD_LOG_GETENT_CTX, NSCD_LOG_LEVEL_DEBUG)
362 		(me, "getent context allocated %p\n", gnctx);
363 	}
364 
365 	gnctx->dbi = params->dbi;
366 	gnctx->cookie_num = _nscd_get_cookie_num();
367 	gnctx->pid = -1;
368 	(void) mutex_init(&gnctx->getent_mutex, USYNC_THREAD, NULL);
369 
370 	if (_nscd_get_nsw_state(&db_root, params) != NSCD_SUCCESS) {
371 		free(gnctx);
372 		return (NULL);
373 	}
374 	gnctx->nsw_state = (nscd_nsw_state_t *)db_root.s;
375 	/* this is a nsw_state used for getent processing */
376 	gnctx->nsw_state->getent = 1;
377 
378 	_NSCD_LOG(NSCD_LOG_GETENT_CTX, NSCD_LOG_LEVEL_DEBUG)
379 	(me, "got nsw_state %p\n", gnctx->nsw_state);
380 
381 	return (gnctx);
382 }
383 
384 
385 nscd_rc_t
386 _nscd_get_getent_ctx(
387 	nss_getent_t		*contextpp,
388 	nscd_nsw_params_t	*params)
389 {
390 
391 	nscd_getent_context_t	*c;
392 	nscd_getent_ctx_base_t	*base, *tmp;
393 	nscd_rc_t		rc;
394 	char			*me = "_nscd_get_getent_ctx";
395 
396 	_NSCD_LOG(NSCD_LOG_GETENT_CTX, NSCD_LOG_LEVEL_DEBUG)
397 	(me, "entering ...\n");
398 
399 	(void) rw_rdlock(&nscd_getent_ctx_base_lock);
400 	base = nscd_getent_ctx_base[params->dbi];
401 	(void) rw_unlock(&nscd_getent_ctx_base_lock);
402 	assert(base != NULL);
403 
404 	/*
405 	 * If the context list is not empty, return the first one
406 	 * on the list. Otherwise, create and return a new one if
407 	 * limit is not reached. If limit is reached return an error
408 	 * so that the client can perform the enumeration.
409 	 */
410 	tmp = (nscd_getent_ctx_base_t *)_nscd_mutex_lock(
411 	    (nscd_acc_data_t *)base);
412 	assert(base == tmp);
413 	if (base->first == NULL) {
414 		if (base->num_getent_ctx >= base->max_getent_ctx) {
415 			/* run out of contexts */
416 
417 			_NSCD_LOG(NSCD_LOG_GETENT_CTX,
418 			    NSCD_LOG_LEVEL_DEBUG)
419 			(me, "run out of getent ctxs\n");
420 
421 			_nscd_mutex_unlock((nscd_acc_data_t *)base);
422 			return (NSCD_CREATE_GETENT_CTX_FAILED);
423 		} else {
424 			base->first = _nscd_create_getent_ctx(params);
425 			if (base->first != NULL)
426 				base->num_getent_ctx++;
427 			else {
428 				/* not able to create a getent ctx */
429 
430 				_NSCD_LOG(NSCD_LOG_GETENT_CTX,
431 				    NSCD_LOG_LEVEL_ERROR)
432 				(me, "create getent ctx failed\n");
433 
434 				_nscd_mutex_unlock((nscd_acc_data_t *)base);
435 				return (NSCD_CREATE_GETENT_CTX_FAILED);
436 			}
437 
438 			_NSCD_LOG(NSCD_LOG_GETENT_CTX, NSCD_LOG_LEVEL_DEBUG)
439 			(me, "got a new getent ctx %p\n", base->first);
440 		}
441 	}
442 
443 	assert(base->first != NULL);
444 
445 	c = base->first;
446 	base->first = c->next;
447 	c->next = NULL;
448 	c->seq_num = 1;
449 	c->cookie_num = _nscd_get_cookie_num();
450 	c->in_use = 1;
451 	c->thr_id = thr_self();
452 
453 	_NSCD_LOG(NSCD_LOG_GETENT_CTX, NSCD_LOG_LEVEL_DEBUG)
454 	(me, "got a getent ctx %p\n", c);
455 
456 	/*
457 	 * reference count the getent context base bfore handing out
458 	 * the getent context
459 	 */
460 	c->base = (nscd_getent_ctx_base_t *)
461 	    _nscd_get((nscd_acc_data_t *)base);
462 
463 	_nscd_mutex_unlock((nscd_acc_data_t *)base);
464 
465 	_NSCD_LOG(NSCD_LOG_GETENT_CTX, NSCD_LOG_LEVEL_DEBUG)
466 	(me, "adding new ctx %p, cookie # = %lld\n", c, c->cookie_num);
467 
468 	if ((rc = _nscd_add_getent_ctx(c, c->cookie_num)) != NSCD_SUCCESS) {
469 		_nscd_put_getent_ctx(c);
470 		return (rc);
471 	}
472 	contextpp->ctx = (struct nss_getent_context *)c;
473 
474 	/* start monitor and reclaim orphan getent context */
475 	if (getent_monitor_started == 0) {
476 		(void) mutex_lock(&getent_monitor_mutex);
477 		if (getent_monitor_started == 0) {
478 			getent_monitor_started = 1;
479 			(void) _nscd_init_getent_ctx_monitor();
480 		}
481 		(void) mutex_unlock(&getent_monitor_mutex);
482 	}
483 
484 	return (NSCD_SUCCESS);
485 }
486 
487 void
488 _nscd_put_getent_ctx(
489 	nscd_getent_context_t	*gnctx)
490 {
491 
492 	nscd_getent_ctx_base_t	*base;
493 	char			*me = "_nscd_put_getent_ctx";
494 
495 	base = gnctx->base;
496 
497 	/* if context base is gone or no longer current, free this context */
498 	if ((_nscd_mutex_lock((nscd_acc_data_t *)base)) == NULL) {
499 		_nscd_free_getent_ctx(gnctx);
500 		return;
501 	}
502 
503 	if (base->first != NULL) {
504 		gnctx->next = base->first;
505 		base->first = gnctx;
506 	} else
507 		base->first = gnctx;
508 
509 	/* put back the db state */
510 	_NSCD_LOG(NSCD_LOG_GETENT_CTX, NSCD_LOG_LEVEL_DEBUG)
511 	(me, "putting back nsw state %p\n", gnctx->nsw_state);
512 
513 	/* this nsw_state is no longer used for getent processing */
514 	if (gnctx->nsw_state != NULL) {
515 		gnctx->nsw_state->getent = 0;
516 		_nscd_put_nsw_state(gnctx->nsw_state);
517 		gnctx->nsw_state = NULL;
518 	}
519 
520 	gnctx->aborted = 0;
521 	gnctx->in_use = 0;
522 	gnctx->thr_id = (thread_t)-1;
523 	_nscd_del_getent_ctx(gnctx, gnctx->cookie_num);
524 
525 	_NSCD_LOG(NSCD_LOG_GETENT_CTX, NSCD_LOG_LEVEL_DEBUG)
526 	(me, "ctx (%p, cookie # = %lld) removed from getent ctx DB\n",
527 	    gnctx, gnctx->cookie_num);
528 
529 	gnctx->seq_num = 0;
530 	gnctx->cookie_num = 0;
531 	gnctx->pid = -1;
532 	gnctx->thr_id = (thread_t)-1;
533 	gnctx->n_src = 0;
534 	gnctx->be = NULL;
535 
536 	/* remove reference to the getent context base */
537 	_nscd_release((nscd_acc_data_t *)base);
538 	gnctx->base = NULL;
539 
540 	_nscd_mutex_unlock((nscd_acc_data_t *)base);
541 }
542 
543 nscd_rc_t
544 _nscd_init_getent_ctx_base(
545 	int			dbi,
546 	int			lock)
547 {
548 	nscd_getent_ctx_base_t	*base = NULL;
549 	char			*me = "_nscd_init_getent_ctx_base";
550 
551 	if (lock)
552 		(void) rw_rdlock(&nscd_getent_ctx_base_lock);
553 
554 	base = (nscd_getent_ctx_base_t *)_nscd_alloc(
555 	    NSCD_DATA_GETENT_CTX_BASE,
556 	    sizeof (nscd_getent_ctx_base_t),
557 	    _nscd_free_getent_ctx_base,
558 	    NSCD_ALLOC_MUTEX | NSCD_ALLOC_COND);
559 
560 	if (base == NULL) {
561 		if (lock)
562 			(void) rw_unlock(&nscd_getent_ctx_base_lock);
563 		return (NSCD_NO_MEMORY);
564 	}
565 	_NSCD_LOG(NSCD_LOG_GETENT_CTX | NSCD_LOG_CONFIG, NSCD_LOG_LEVEL_DEBUG)
566 	(me, "base %p allocated\n", base);
567 
568 	/*
569 	 * initialize and activate the new getent_ctx base
570 	 */
571 	base->dbi = dbi;
572 	base->max_getent_ctx = NSCD_SW_CFG(dbi).max_getent_ctx_per_db;
573 	nscd_getent_ctx_base[dbi] =
574 	    (nscd_getent_ctx_base_t *)_nscd_set(
575 	    (nscd_acc_data_t *)nscd_getent_ctx_base[dbi],
576 	    (nscd_acc_data_t *)base);
577 
578 	if (lock)
579 		(void) rw_unlock(&nscd_getent_ctx_base_lock);
580 
581 	return (NSCD_SUCCESS);
582 }
583 
584 nscd_rc_t
585 _nscd_init_all_getent_ctx_base()
586 {
587 	int			i;
588 	nscd_rc_t		rc;
589 	char			*me = "_nscd_init_all_getent_ctx_base";
590 
591 	(void) rw_wrlock(&nscd_getent_ctx_base_lock);
592 
593 	for (i = 0; i < NSCD_NUM_DB; i++) {
594 
595 		rc = _nscd_init_getent_ctx_base(i, 0);
596 
597 		if (rc != NSCD_SUCCESS) {
598 			(void) rw_unlock(&nscd_getent_ctx_base_lock);
599 			return (rc);
600 		}
601 	}
602 
603 	_NSCD_LOG(NSCD_LOG_GETENT_CTX | NSCD_LOG_CONFIG, NSCD_LOG_LEVEL_DEBUG)
604 	(me, "all getent context base initialized\n");
605 
606 	(void) rw_unlock(&nscd_getent_ctx_base_lock);
607 
608 	return (NSCD_SUCCESS);
609 }
610 nscd_rc_t
611 _nscd_alloc_getent_ctx_base()
612 {
613 
614 	(void) rw_wrlock(&nscd_getent_ctx_base_lock);
615 
616 	nscd_getent_ctx_base = calloc(NSCD_NUM_DB,
617 	    sizeof (nscd_getent_ctx_base_t *));
618 	if (nscd_getent_ctx_base == NULL) {
619 		(void) rw_unlock(&nscd_getent_ctx_base_lock);
620 		return (NSCD_NO_MEMORY);
621 	}
622 
623 	(void) rw_unlock(&nscd_getent_ctx_base_lock);
624 
625 	return (NSCD_SUCCESS);
626 }
627 
628 static int
629 process_exited(pid_t pid)
630 {
631 	char	pname[PATH_MAX];
632 	int	fd;
633 
634 	(void) snprintf(pname, sizeof (pname), "/proc/%d/psinfo", pid);
635 	if ((fd = open(pname, O_RDONLY)) == -1)
636 		return (1);
637 	else {
638 		(void) close(fd);
639 		return (0);
640 	}
641 }
642 
643 /*
644  * FUNCTION: reclaim_getent_ctx
645  */
646 /*ARGSUSED*/
647 static void *
648 reclaim_getent_ctx(void *arg)
649 {
650 	void			*cookie = NULL;
651 	nscd_db_entry_t		*ep;
652 	nscd_getent_ctx_t	*ctx;
653 	nscd_getent_context_t	*gctx, *c;
654 	nscd_getent_context_t	*first = NULL, *last = NULL;
655 	nss_getent_t		nssctx = { 0 };
656 	char			*me = "reclaim_getent_ctx";
657 
658 	/*CONSTCOND*/
659 	while (1) {
660 
661 		(void) sleep(60);
662 
663 		(void) rw_rdlock(&getent_ctxDB_rwlock);
664 
665 		for (ep = _nscd_walk_db(getent_ctxDB, &cookie); ep != NULL;
666 		    ep = _nscd_walk_db(getent_ctxDB, &cookie)) {
667 
668 			ctx = (nscd_getent_ctx_t *)*(ep->data_array);
669 
670 			gctx = ctx->ptr;
671 
672 			/*
673 			 * if the client process, which did the setent,
674 			 * exited, add the context to the orphan list
675 			 */
676 			if (gctx->pid != -1 && process_exited(gctx->pid)) {
677 
678 				_NSCD_LOG(NSCD_LOG_GETENT_CTX,
679 				    NSCD_LOG_LEVEL_DEBUG)
680 				(me, "process  %d exited, "
681 				    "getent context = %p, "
682 				    "db index = %d, cookie # = %lld, "
683 				    "sequence # = %lld\n",
684 				    gctx->pid, gctx, gctx->dbi,
685 				    gctx->cookie_num, gctx->seq_num);
686 
687 				if (first != NULL) {
688 					/* add to list if not in already */
689 					for (c = first; c != NULL;
690 					    c = c->next_to_reclaim) {
691 						if (gctx == c)
692 							break;
693 					}
694 					if (c == NULL) {
695 						last->next_to_reclaim = gctx;
696 						last = gctx;
697 					}
698 				} else {
699 					first = gctx;
700 					last = gctx;
701 				}
702 			}
703 		}
704 
705 		(void) rw_unlock(&getent_ctxDB_rwlock);
706 
707 
708 		/*
709 		 * return all the orphan getent contexts to the pool if not
710 		 * in use
711 		 */
712 		for (gctx = first; gctx; ) {
713 			int in_use, num_reclaim_check;
714 
715 			c = gctx->next_to_reclaim;
716 			gctx->next_to_reclaim = NULL;
717 			gctx->aborted = 1;
718 
719 			(void) mutex_lock(&gctx->getent_mutex);
720 			num_reclaim_check = gctx->num_reclaim_check++;
721 			if (num_reclaim_check > 1)
722 				gctx->in_use = 0;
723 			in_use = gctx->in_use;
724 			(void) mutex_unlock(&gctx->getent_mutex);
725 
726 			if (in_use == 0) {
727 				_NSCD_LOG(NSCD_LOG_GETENT_CTX,
728 				    NSCD_LOG_LEVEL_DEBUG)
729 				(me, "process  %d exited, "
730 				    "freeing getent context = %p\n",
731 				    gctx->pid, gctx);
732 				nssctx.ctx = (struct nss_getent_context *)gctx;
733 				nss_endent(NULL, NULL, &nssctx);
734 			}
735 			gctx = c;
736 		}
737 		first = last = NULL;
738 	}
739 	/*NOTREACHED*/
740 	/*LINTED E_FUNC_HAS_NO_RETURN_STMT*/
741 }
742 
743 static nscd_rc_t
744 _nscd_init_getent_ctx_monitor() {
745 
746 	int	errnum;
747 	char	*me = "_nscd_init_getent_ctx_monitor";
748 
749 	_NSCD_LOG(NSCD_LOG_GETENT_CTX, NSCD_LOG_LEVEL_DEBUG)
750 	(me, "initializing the getent context monitor\n");
751 
752 	/*
753 	 * the forker nscd does not process getent requests
754 	 * so no need to monitor orphan getent contexts
755 	 */
756 	if (_whoami == NSCD_FORKER)
757 		return (NSCD_SUCCESS);
758 
759 	/*
760 	 * start a thread to reclaim unused getent contexts
761 	 */
762 	if (thr_create(NULL, NULL, reclaim_getent_ctx,
763 		NULL, THR_DETACHED, NULL) != 0) {
764 		errnum = errno;
765 		_NSCD_LOG(NSCD_LOG_GETENT_CTX, NSCD_LOG_LEVEL_ERROR)
766 		(me, "thr_create: %s\n", strerror(errnum));
767 		return (NSCD_THREAD_CREATE_ERROR);
768 	}
769 
770 	return (NSCD_SUCCESS);
771 }
772