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 /*
22cfed26cbSMichen Chang * Copyright 2009 Sun Microsystems, Inc. All rights reserved.
23cb5caa98Sdjl * Use is subject to license terms.
24cb5caa98Sdjl */
25cb5caa98Sdjl
26*9e293969SRichard Lowe #include <sys/ccompile.h>
27*9e293969SRichard Lowe
28cb5caa98Sdjl #include <stdlib.h>
29cb5caa98Sdjl #include <assert.h>
30cb5caa98Sdjl #include <string.h>
31cb5caa98Sdjl #include <errno.h>
32cb5caa98Sdjl #include <fcntl.h>
33*9e293969SRichard Lowe
34cb5caa98Sdjl #include "nscd_db.h"
35cb5caa98Sdjl #include "nscd_log.h"
36cb5caa98Sdjl #include "nscd_switch.h"
37cb5caa98Sdjl #include "nscd_door.h"
38cb5caa98Sdjl
39cb5caa98Sdjl extern int _whoami;
40cb5caa98Sdjl static mutex_t getent_monitor_mutex = DEFAULTMUTEX;
41cb5caa98Sdjl static int getent_monitor_started = 0;
42cb5caa98Sdjl
43cb5caa98Sdjl static rwlock_t getent_ctxDB_rwlock = DEFAULTRWLOCK;
44cb5caa98Sdjl static nscd_db_t *getent_ctxDB = NULL;
45cb5caa98Sdjl
46cb5caa98Sdjl /*
47cb5caa98Sdjl * internal structure representing a nscd getent context
48cb5caa98Sdjl */
49cb5caa98Sdjl typedef struct nscd_getent_ctx {
50cb5caa98Sdjl int to_delete; /* this ctx no longer valid */
51cb5caa98Sdjl nscd_getent_context_t *ptr;
52e37190e5Smichen nscd_cookie_num_t cookie_num;
53cb5caa98Sdjl } nscd_getent_ctx_t;
54cb5caa98Sdjl
55cb5caa98Sdjl /*
56cb5caa98Sdjl * nscd_getent_context_t list for each nss database. Protected
57cb5caa98Sdjl * by the readers/writer lock nscd_getent_ctx_lock.
58cb5caa98Sdjl */
59cb5caa98Sdjl nscd_getent_ctx_base_t **nscd_getent_ctx_base;
60cb5caa98Sdjl static rwlock_t nscd_getent_ctx_base_lock = DEFAULTRWLOCK;
61cb5caa98Sdjl
62cb5caa98Sdjl extern nscd_db_entry_t *_nscd_walk_db(nscd_db_t *db, void **cookie);
63cb5caa98Sdjl
64cb5caa98Sdjl static nscd_rc_t _nscd_init_getent_ctx_monitor();
65cb5caa98Sdjl
66cb5caa98Sdjl /*
67cb5caa98Sdjl * FUNCTION: _nscd_create_getent_ctxDB
68cb5caa98Sdjl *
69cb5caa98Sdjl * Create the internal getent context database to keep track of the
70cb5caa98Sdjl * getent contexts currently being used.
71cb5caa98Sdjl */
72cb5caa98Sdjl nscd_db_t *
_nscd_create_getent_ctxDB()73cb5caa98Sdjl _nscd_create_getent_ctxDB()
74cb5caa98Sdjl {
75cb5caa98Sdjl
76cb5caa98Sdjl nscd_db_t *ret;
77cb5caa98Sdjl
78cb5caa98Sdjl (void) rw_wrlock(&getent_ctxDB_rwlock);
79cb5caa98Sdjl
80cb5caa98Sdjl if (getent_ctxDB != NULL) {
81cb5caa98Sdjl (void) rw_unlock(&getent_ctxDB_rwlock);
82cb5caa98Sdjl return (getent_ctxDB);
83cb5caa98Sdjl }
84cb5caa98Sdjl
85cb5caa98Sdjl ret = _nscd_alloc_db(NSCD_DB_SIZE_LARGE);
86cb5caa98Sdjl
87cb5caa98Sdjl if (ret != NULL)
88cb5caa98Sdjl getent_ctxDB = ret;
89cb5caa98Sdjl
90cb5caa98Sdjl (void) rw_unlock(&getent_ctxDB_rwlock);
91cb5caa98Sdjl
92cb5caa98Sdjl return (ret);
93cb5caa98Sdjl }
94cb5caa98Sdjl
95cb5caa98Sdjl /*
96cb5caa98Sdjl * FUNCTION: _nscd_add_getent_ctx
97cb5caa98Sdjl *
98cb5caa98Sdjl * Add a getent context to the internal context database.
99cb5caa98Sdjl */
100cb5caa98Sdjl static nscd_rc_t
_nscd_add_getent_ctx(nscd_getent_context_t * ptr,nscd_cookie_num_t cookie_num)101cb5caa98Sdjl _nscd_add_getent_ctx(
102cb5caa98Sdjl nscd_getent_context_t *ptr,
103e37190e5Smichen nscd_cookie_num_t cookie_num)
104cb5caa98Sdjl {
105cb5caa98Sdjl int size;
10629836b19Smichen char buf[32];
107cb5caa98Sdjl nscd_db_entry_t *db_entry;
108cb5caa98Sdjl nscd_getent_ctx_t *gnctx;
109cb5caa98Sdjl
110cb5caa98Sdjl if (ptr == NULL)
111cb5caa98Sdjl return (NSCD_INVALID_ARGUMENT);
112cb5caa98Sdjl
113e37190e5Smichen (void) snprintf(buf, sizeof (buf), "%lld", cookie_num);
114cb5caa98Sdjl
115cb5caa98Sdjl size = sizeof (*gnctx);
116cb5caa98Sdjl
117cb5caa98Sdjl db_entry = _nscd_alloc_db_entry(NSCD_DATA_CTX_ADDR,
118cb5caa98Sdjl (const char *)buf, size, 1, 1);
119cb5caa98Sdjl if (db_entry == NULL)
120cb5caa98Sdjl return (NSCD_NO_MEMORY);
121cb5caa98Sdjl
122cb5caa98Sdjl gnctx = (nscd_getent_ctx_t *)*(db_entry->data_array);
123cb5caa98Sdjl gnctx->ptr = ptr;
124e37190e5Smichen gnctx->cookie_num = cookie_num;
125cb5caa98Sdjl
126cb5caa98Sdjl (void) rw_wrlock(&getent_ctxDB_rwlock);
127cb5caa98Sdjl (void) _nscd_add_db_entry(getent_ctxDB, buf, db_entry,
128cb5caa98Sdjl NSCD_ADD_DB_ENTRY_FIRST);
129cb5caa98Sdjl (void) rw_unlock(&getent_ctxDB_rwlock);
130cb5caa98Sdjl
131cb5caa98Sdjl return (NSCD_SUCCESS);
132cb5caa98Sdjl }
133cb5caa98Sdjl
134cb5caa98Sdjl /*
135cb5caa98Sdjl * FUNCTION: _nscd_is_getent_ctx
136cb5caa98Sdjl *
137cb5caa98Sdjl * Check to see if a getent context can be found in the internal
138cb5caa98Sdjl * getent context database.
139cb5caa98Sdjl */
140cb5caa98Sdjl nscd_getent_context_t *
_nscd_is_getent_ctx(nscd_cookie_num_t cookie_num)141cb5caa98Sdjl _nscd_is_getent_ctx(
142e37190e5Smichen nscd_cookie_num_t cookie_num)
143cb5caa98Sdjl {
14429836b19Smichen char ptrstr[32];
145cb5caa98Sdjl const nscd_db_entry_t *db_entry;
146cb5caa98Sdjl nscd_getent_context_t *ret = NULL;
1476392794bSMichen Chang char *me = "_nscd_is_getent_ctx";
148cb5caa98Sdjl
149e37190e5Smichen (void) snprintf(ptrstr, sizeof (ptrstr), "%lld", cookie_num);
150cb5caa98Sdjl
151cb5caa98Sdjl (void) rw_rdlock(&getent_ctxDB_rwlock);
152cb5caa98Sdjl
153cb5caa98Sdjl db_entry = _nscd_get_db_entry(getent_ctxDB, NSCD_DATA_CTX_ADDR,
154cb5caa98Sdjl (const char *)ptrstr, NSCD_GET_FIRST_DB_ENTRY, 0);
155cb5caa98Sdjl
156cb5caa98Sdjl if (db_entry != NULL) {
157cb5caa98Sdjl nscd_getent_ctx_t *gnctx;
158cb5caa98Sdjl
159cb5caa98Sdjl gnctx = (nscd_getent_ctx_t *)*(db_entry->data_array);
1606392794bSMichen Chang _NSCD_LOG(NSCD_LOG_GETENT_CTX, NSCD_LOG_LEVEL_DEBUG)
1616392794bSMichen Chang (me, "getent context %p, cookie# %lld, to_delete %d\n",
1626392794bSMichen Chang gnctx->ptr, gnctx->cookie_num, gnctx->to_delete);
163cb5caa98Sdjl
164cb5caa98Sdjl /*
1656392794bSMichen Chang * If the ctx is not to be deleted and the cookie numbers
166cfed26cbSMichen Chang * match, return the ctx if not aborted and not in use.
167cb5caa98Sdjl * Otherwise return NULL.
168cb5caa98Sdjl */
16929836b19Smichen if (gnctx->to_delete == 0 && gnctx->cookie_num == cookie_num) {
170cb5caa98Sdjl ret = gnctx->ptr;
17129836b19Smichen (void) mutex_lock(&gnctx->ptr->getent_mutex);
17229836b19Smichen if (ret->aborted == 1 || ret->in_use == 1)
17329836b19Smichen ret = NULL;
17429836b19Smichen else
17529836b19Smichen ret->in_use = 1;
17629836b19Smichen (void) mutex_unlock(&gnctx->ptr->getent_mutex);
17729836b19Smichen }
178cb5caa98Sdjl }
179cb5caa98Sdjl
180cb5caa98Sdjl (void) rw_unlock(&getent_ctxDB_rwlock);
181cb5caa98Sdjl
182cb5caa98Sdjl return (ret);
183cb5caa98Sdjl }
184cb5caa98Sdjl
1856392794bSMichen Chang int
_nscd_is_getent_ctx_in_use(nscd_getent_context_t * ctx)1866392794bSMichen Chang _nscd_is_getent_ctx_in_use(
1876392794bSMichen Chang nscd_getent_context_t *ctx)
1886392794bSMichen Chang {
1896392794bSMichen Chang int in_use;
1906392794bSMichen Chang char *me = "_nscd_getent_ctx_in_use";
1916392794bSMichen Chang
1926392794bSMichen Chang (void) mutex_lock(&ctx->getent_mutex);
1936392794bSMichen Chang
1946392794bSMichen Chang _NSCD_LOG(NSCD_LOG_GETENT_CTX, NSCD_LOG_LEVEL_DEBUG)
1956392794bSMichen Chang (me, "in_use = %d, ctx->thr_id = %d, thread id = %d\n",
1966392794bSMichen Chang ctx->in_use, ctx->thr_id, thr_self());
1976392794bSMichen Chang
1986392794bSMichen Chang in_use = ctx->in_use;
1996392794bSMichen Chang if (in_use == 1 && ctx->thr_id == thr_self())
2006392794bSMichen Chang in_use = 0;
2016392794bSMichen Chang (void) mutex_unlock(&ctx->getent_mutex);
2026392794bSMichen Chang return (in_use);
2036392794bSMichen Chang }
2046392794bSMichen Chang
205cb5caa98Sdjl /*
20629836b19Smichen * FUNCTION: _nscd_free_ctx_if_aborted
20729836b19Smichen *
20829836b19Smichen * Check to see if the getent session associated with a getent context had
20929836b19Smichen * been aborted. If so, return the getent context back to the pool.
21029836b19Smichen */
21129836b19Smichen void
_nscd_free_ctx_if_aborted(nscd_getent_context_t * ctx)21229836b19Smichen _nscd_free_ctx_if_aborted(
21329836b19Smichen nscd_getent_context_t *ctx)
21429836b19Smichen {
21529836b19Smichen int aborted;
21629836b19Smichen char *me = "_nscd_free_ctx_if_aborted";
21729836b19Smichen
21829836b19Smichen (void) mutex_lock(&ctx->getent_mutex);
2196392794bSMichen Chang
2206392794bSMichen Chang _NSCD_LOG(NSCD_LOG_GETENT_CTX, NSCD_LOG_LEVEL_DEBUG)
2216392794bSMichen Chang (me, "in_use = %d, aborted = %d\n", ctx->in_use, ctx->aborted);
2226392794bSMichen Chang
2236392794bSMichen Chang if (ctx->in_use != 1) {
2246392794bSMichen Chang (void) mutex_unlock(&ctx->getent_mutex);
2256392794bSMichen Chang return;
2266392794bSMichen Chang }
22729836b19Smichen aborted = ctx->aborted;
2286392794bSMichen Chang ctx->in_use = 0;
22929836b19Smichen (void) mutex_unlock(&ctx->getent_mutex);
23029836b19Smichen
23129836b19Smichen if (aborted == 1) {
23229836b19Smichen _NSCD_LOG(NSCD_LOG_GETENT_CTX, NSCD_LOG_LEVEL_DEBUG)
23329836b19Smichen (me, "getent session aborted, return the getent context\n");
23429836b19Smichen _nscd_put_getent_ctx(ctx);
23529836b19Smichen }
23629836b19Smichen }
23729836b19Smichen
23829836b19Smichen /*
239cb5caa98Sdjl * FUNCTION: _nscd_del_getent_ctx
240cb5caa98Sdjl *
241cb5caa98Sdjl * Delete a getent context from the internal getent context database.
242cb5caa98Sdjl */
243cb5caa98Sdjl static void
_nscd_del_getent_ctx(nscd_getent_context_t * ptr,nscd_cookie_num_t cookie_num)244cb5caa98Sdjl _nscd_del_getent_ctx(
245cb5caa98Sdjl nscd_getent_context_t *ptr,
246e37190e5Smichen nscd_cookie_num_t cookie_num)
247cb5caa98Sdjl {
24829836b19Smichen char ptrstr[32];
249cb5caa98Sdjl nscd_getent_ctx_t *gnctx;
250cb5caa98Sdjl const nscd_db_entry_t *db_entry;
251cb5caa98Sdjl
252cb5caa98Sdjl if (ptr == NULL)
253cb5caa98Sdjl return;
254cb5caa98Sdjl
255e37190e5Smichen (void) snprintf(ptrstr, sizeof (ptrstr), "%lld", cookie_num);
256cb5caa98Sdjl
257cb5caa98Sdjl (void) rw_rdlock(&getent_ctxDB_rwlock);
258cb5caa98Sdjl /*
259cb5caa98Sdjl * first find the db entry and make sure the
260cb5caa98Sdjl * sequence number matched, then delete it from
261cb5caa98Sdjl * the database.
262cb5caa98Sdjl */
263cb5caa98Sdjl db_entry = _nscd_get_db_entry(getent_ctxDB,
264cb5caa98Sdjl NSCD_DATA_CTX_ADDR,
265cb5caa98Sdjl (const char *)ptrstr,
266cb5caa98Sdjl NSCD_GET_FIRST_DB_ENTRY, 0);
267cb5caa98Sdjl if (db_entry != NULL) {
268cb5caa98Sdjl gnctx = (nscd_getent_ctx_t *)*(db_entry->data_array);
269e37190e5Smichen if (gnctx->ptr == ptr && gnctx->cookie_num == cookie_num) {
270cb5caa98Sdjl
271cb5caa98Sdjl (void) rw_unlock(&getent_ctxDB_rwlock);
272cb5caa98Sdjl (void) rw_wrlock(&getent_ctxDB_rwlock);
273cb5caa98Sdjl
274cb5caa98Sdjl (void) _nscd_delete_db_entry(getent_ctxDB,
275cb5caa98Sdjl NSCD_DATA_CTX_ADDR,
276cb5caa98Sdjl (const char *)ptrstr,
277cb5caa98Sdjl NSCD_DEL_FIRST_DB_ENTRY, 0);
278cb5caa98Sdjl }
279cb5caa98Sdjl }
280cb5caa98Sdjl (void) rw_unlock(&getent_ctxDB_rwlock);
281cb5caa98Sdjl }
282cb5caa98Sdjl
283cb5caa98Sdjl static void
_nscd_free_getent_ctx(nscd_getent_context_t * gnctx)284cb5caa98Sdjl _nscd_free_getent_ctx(
285cb5caa98Sdjl nscd_getent_context_t *gnctx)
286cb5caa98Sdjl {
287cb5caa98Sdjl
288cb5caa98Sdjl char *me = "_nscd_free_getent_ctx";
289cb5caa98Sdjl
290cb5caa98Sdjl _NSCD_LOG(NSCD_LOG_GETENT_CTX, NSCD_LOG_LEVEL_DEBUG)
291cb5caa98Sdjl (me, "getent context %p\n", gnctx);
292cb5caa98Sdjl
293cb5caa98Sdjl _nscd_put_nsw_state(gnctx->nsw_state);
294cfed26cbSMichen Chang
295cfed26cbSMichen Chang if (gnctx->base != NULL) {
296cfed26cbSMichen Chang /* remove reference to the getent context base */
297cfed26cbSMichen Chang _nscd_release((nscd_acc_data_t *)gnctx->base);
298cfed26cbSMichen Chang gnctx->base = NULL;
299cfed26cbSMichen Chang }
300cfed26cbSMichen Chang
301e37190e5Smichen _nscd_del_getent_ctx(gnctx, gnctx->cookie_num);
302cb5caa98Sdjl free(gnctx);
303cb5caa98Sdjl }
304cb5caa98Sdjl
305cb5caa98Sdjl
306cb5caa98Sdjl static void
_nscd_free_getent_ctx_base(nscd_acc_data_t * data)307cb5caa98Sdjl _nscd_free_getent_ctx_base(
308cb5caa98Sdjl nscd_acc_data_t *data)
309cb5caa98Sdjl {
310cb5caa98Sdjl nscd_getent_ctx_base_t *base = (nscd_getent_ctx_base_t *)data;
311cb5caa98Sdjl nscd_getent_context_t *c, *tc;
312cb5caa98Sdjl char *me = "_nscd_free_getent_ctx_base";
313cb5caa98Sdjl
314cb5caa98Sdjl _NSCD_LOG(NSCD_LOG_GETENT_CTX | NSCD_LOG_CONFIG, NSCD_LOG_LEVEL_DEBUG)
315cb5caa98Sdjl (me, "getent context base %p\n", base);
316cb5caa98Sdjl
317cb5caa98Sdjl if (base == NULL)
318cb5caa98Sdjl return;
319cb5caa98Sdjl
320cb5caa98Sdjl c = base->first;
321cb5caa98Sdjl while (c != NULL) {
322cb5caa98Sdjl tc = c->next;
323cb5caa98Sdjl _nscd_free_getent_ctx(c);
324cb5caa98Sdjl c = tc;
325cb5caa98Sdjl }
326cb5caa98Sdjl }
327cb5caa98Sdjl
328cb5caa98Sdjl void
_nscd_free_all_getent_ctx_base()329cb5caa98Sdjl _nscd_free_all_getent_ctx_base()
330cb5caa98Sdjl {
331cb5caa98Sdjl nscd_getent_ctx_base_t *base;
332cb5caa98Sdjl int i;
333cb5caa98Sdjl char *me = "_nscd_free_all_getent_ctx_base";
334cb5caa98Sdjl
335cb5caa98Sdjl _NSCD_LOG(NSCD_LOG_GETENT_CTX | NSCD_LOG_CONFIG, NSCD_LOG_LEVEL_DEBUG)
336cb5caa98Sdjl (me, "entering ..\n");
337cb5caa98Sdjl
338cb5caa98Sdjl (void) rw_wrlock(&nscd_getent_ctx_base_lock);
339cb5caa98Sdjl
340cb5caa98Sdjl for (i = 0; i < NSCD_NUM_DB; i++) {
341cb5caa98Sdjl
342cb5caa98Sdjl base = nscd_getent_ctx_base[i];
343cb5caa98Sdjl if (base == NULL)
344cb5caa98Sdjl continue;
345cb5caa98Sdjl
346cb5caa98Sdjl nscd_getent_ctx_base[i] = (nscd_getent_ctx_base_t *)
347cb5caa98Sdjl _nscd_set((nscd_acc_data_t *)base, NULL);
348cb5caa98Sdjl }
349cb5caa98Sdjl (void) rw_unlock(&nscd_getent_ctx_base_lock);
350cb5caa98Sdjl }
351cb5caa98Sdjl
352cb5caa98Sdjl static nscd_getent_context_t *
_nscd_create_getent_ctx(nscd_nsw_params_t * params)353cb5caa98Sdjl _nscd_create_getent_ctx(
354cb5caa98Sdjl nscd_nsw_params_t *params)
355cb5caa98Sdjl {
356cb5caa98Sdjl nscd_getent_context_t *gnctx;
357cb5caa98Sdjl nss_db_root_t db_root;
358cb5caa98Sdjl char *me = "_nscd_create_getent_ctx";
359cb5caa98Sdjl
360cb5caa98Sdjl gnctx = calloc(1, sizeof (nscd_getent_context_t));
361cb5caa98Sdjl if (gnctx == NULL)
362cb5caa98Sdjl return (NULL);
363cb5caa98Sdjl else {
364cb5caa98Sdjl _NSCD_LOG(NSCD_LOG_GETENT_CTX, NSCD_LOG_LEVEL_DEBUG)
365cb5caa98Sdjl (me, "getent context allocated %p\n", gnctx);
366cb5caa98Sdjl }
367cb5caa98Sdjl
368cb5caa98Sdjl gnctx->dbi = params->dbi;
369e37190e5Smichen gnctx->cookie_num = _nscd_get_cookie_num();
3709f590749Smichen gnctx->pid = -1;
37129836b19Smichen (void) mutex_init(&gnctx->getent_mutex, USYNC_THREAD, NULL);
372cb5caa98Sdjl
373cb5caa98Sdjl if (_nscd_get_nsw_state(&db_root, params) != NSCD_SUCCESS) {
374cb5caa98Sdjl free(gnctx);
375cb5caa98Sdjl return (NULL);
376cb5caa98Sdjl }
377cb5caa98Sdjl gnctx->nsw_state = (nscd_nsw_state_t *)db_root.s;
378cb5caa98Sdjl /* this is a nsw_state used for getent processing */
379cb5caa98Sdjl gnctx->nsw_state->getent = 1;
380cb5caa98Sdjl
381cb5caa98Sdjl _NSCD_LOG(NSCD_LOG_GETENT_CTX, NSCD_LOG_LEVEL_DEBUG)
382cb5caa98Sdjl (me, "got nsw_state %p\n", gnctx->nsw_state);
383cb5caa98Sdjl
384cb5caa98Sdjl return (gnctx);
385cb5caa98Sdjl }
386cb5caa98Sdjl
387cb5caa98Sdjl
388cb5caa98Sdjl nscd_rc_t
_nscd_get_getent_ctx(nss_getent_t * contextpp,nscd_nsw_params_t * params)389cb5caa98Sdjl _nscd_get_getent_ctx(
390cb5caa98Sdjl nss_getent_t *contextpp,
391cb5caa98Sdjl nscd_nsw_params_t *params)
392cb5caa98Sdjl {
393cb5caa98Sdjl
394cb5caa98Sdjl nscd_getent_context_t *c;
395cb5caa98Sdjl nscd_getent_ctx_base_t *base, *tmp;
396cb5caa98Sdjl nscd_rc_t rc;
397cb5caa98Sdjl char *me = "_nscd_get_getent_ctx";
398cb5caa98Sdjl
399cb5caa98Sdjl _NSCD_LOG(NSCD_LOG_GETENT_CTX, NSCD_LOG_LEVEL_DEBUG)
400cb5caa98Sdjl (me, "entering ...\n");
401cb5caa98Sdjl
402cb5caa98Sdjl (void) rw_rdlock(&nscd_getent_ctx_base_lock);
403cb5caa98Sdjl base = nscd_getent_ctx_base[params->dbi];
404cb5caa98Sdjl (void) rw_unlock(&nscd_getent_ctx_base_lock);
405cb5caa98Sdjl assert(base != NULL);
406cb5caa98Sdjl
407cb5caa98Sdjl /*
408cb5caa98Sdjl * If the context list is not empty, return the first one
409cb5caa98Sdjl * on the list. Otherwise, create and return a new one if
410978eb144SJulian Pullen * limit is not reached. If limit is reached return an error
411978eb144SJulian Pullen * so that the client can perform the enumeration.
412cb5caa98Sdjl */
413cb5caa98Sdjl tmp = (nscd_getent_ctx_base_t *)_nscd_mutex_lock(
414cb5caa98Sdjl (nscd_acc_data_t *)base);
415cb5caa98Sdjl assert(base == tmp);
416cb5caa98Sdjl if (base->first == NULL) {
417978eb144SJulian Pullen if (base->num_getent_ctx >= base->max_getent_ctx) {
418978eb144SJulian Pullen /* run out of contexts */
419cb5caa98Sdjl
420cb5caa98Sdjl _NSCD_LOG(NSCD_LOG_GETENT_CTX,
421cb5caa98Sdjl NSCD_LOG_LEVEL_DEBUG)
422978eb144SJulian Pullen (me, "run out of getent ctxs\n");
423cb5caa98Sdjl
424978eb144SJulian Pullen _nscd_mutex_unlock((nscd_acc_data_t *)base);
425978eb144SJulian Pullen return (NSCD_CREATE_GETENT_CTX_FAILED);
426cb5caa98Sdjl } else {
427cb5caa98Sdjl base->first = _nscd_create_getent_ctx(params);
428cfed26cbSMichen Chang if (base->first != NULL)
429cb5caa98Sdjl base->num_getent_ctx++;
430cfed26cbSMichen Chang else {
431cfed26cbSMichen Chang /* not able to create a getent ctx */
432cb5caa98Sdjl
433cb5caa98Sdjl _NSCD_LOG(NSCD_LOG_GETENT_CTX,
434cb5caa98Sdjl NSCD_LOG_LEVEL_ERROR)
435cb5caa98Sdjl (me, "create getent ctx failed\n");
436cb5caa98Sdjl
437cb5caa98Sdjl _nscd_mutex_unlock((nscd_acc_data_t *)base);
438cb5caa98Sdjl return (NSCD_CREATE_GETENT_CTX_FAILED);
439cb5caa98Sdjl }
440cb5caa98Sdjl
441cb5caa98Sdjl _NSCD_LOG(NSCD_LOG_GETENT_CTX, NSCD_LOG_LEVEL_DEBUG)
442cb5caa98Sdjl (me, "got a new getent ctx %p\n", base->first);
443cb5caa98Sdjl }
444cb5caa98Sdjl }
445cb5caa98Sdjl
446cb5caa98Sdjl assert(base->first != NULL);
447cb5caa98Sdjl
448cb5caa98Sdjl c = base->first;
449cb5caa98Sdjl base->first = c->next;
450cb5caa98Sdjl c->next = NULL;
451cb5caa98Sdjl c->seq_num = 1;
4526392794bSMichen Chang c->cookie_num = _nscd_get_cookie_num();
45329836b19Smichen c->in_use = 1;
4546392794bSMichen Chang c->thr_id = thr_self();
455cb5caa98Sdjl
456cb5caa98Sdjl _NSCD_LOG(NSCD_LOG_GETENT_CTX, NSCD_LOG_LEVEL_DEBUG)
457cb5caa98Sdjl (me, "got a getent ctx %p\n", c);
458cb5caa98Sdjl
459cfed26cbSMichen Chang /*
460cfed26cbSMichen Chang * reference count the getent context base bfore handing out
461cfed26cbSMichen Chang * the getent context
462cfed26cbSMichen Chang */
463cfed26cbSMichen Chang c->base = (nscd_getent_ctx_base_t *)
464cfed26cbSMichen Chang _nscd_get((nscd_acc_data_t *)base);
465cfed26cbSMichen Chang
466cb5caa98Sdjl _nscd_mutex_unlock((nscd_acc_data_t *)base);
467cb5caa98Sdjl
468cb5caa98Sdjl _NSCD_LOG(NSCD_LOG_GETENT_CTX, NSCD_LOG_LEVEL_DEBUG)
469e37190e5Smichen (me, "adding new ctx %p, cookie # = %lld\n", c, c->cookie_num);
470cb5caa98Sdjl
471e37190e5Smichen if ((rc = _nscd_add_getent_ctx(c, c->cookie_num)) != NSCD_SUCCESS) {
472cb5caa98Sdjl _nscd_put_getent_ctx(c);
473cb5caa98Sdjl return (rc);
474cb5caa98Sdjl }
475cb5caa98Sdjl contextpp->ctx = (struct nss_getent_context *)c;
476cb5caa98Sdjl
477cb5caa98Sdjl /* start monitor and reclaim orphan getent context */
478cb5caa98Sdjl if (getent_monitor_started == 0) {
479cb5caa98Sdjl (void) mutex_lock(&getent_monitor_mutex);
480cb5caa98Sdjl if (getent_monitor_started == 0) {
481cb5caa98Sdjl getent_monitor_started = 1;
482cb5caa98Sdjl (void) _nscd_init_getent_ctx_monitor();
483cb5caa98Sdjl }
484cb5caa98Sdjl (void) mutex_unlock(&getent_monitor_mutex);
485cb5caa98Sdjl }
486cb5caa98Sdjl
487cb5caa98Sdjl return (NSCD_SUCCESS);
488cb5caa98Sdjl }
489cb5caa98Sdjl
490cb5caa98Sdjl void
_nscd_put_getent_ctx(nscd_getent_context_t * gnctx)491cb5caa98Sdjl _nscd_put_getent_ctx(
492cb5caa98Sdjl nscd_getent_context_t *gnctx)
493cb5caa98Sdjl {
494cb5caa98Sdjl
495cb5caa98Sdjl nscd_getent_ctx_base_t *base;
496cb5caa98Sdjl char *me = "_nscd_put_getent_ctx";
497cb5caa98Sdjl
498cb5caa98Sdjl base = gnctx->base;
499cb5caa98Sdjl
500cfed26cbSMichen Chang /* if context base is gone or no longer current, free this context */
501cb5caa98Sdjl if ((_nscd_mutex_lock((nscd_acc_data_t *)base)) == NULL) {
502cb5caa98Sdjl _nscd_free_getent_ctx(gnctx);
503cb5caa98Sdjl return;
504cb5caa98Sdjl }
505cb5caa98Sdjl
506cb5caa98Sdjl if (base->first != NULL) {
507cb5caa98Sdjl gnctx->next = base->first;
508cb5caa98Sdjl base->first = gnctx;
509cb5caa98Sdjl } else
510cb5caa98Sdjl base->first = gnctx;
511cb5caa98Sdjl
512cb5caa98Sdjl /* put back the db state */
513cb5caa98Sdjl _NSCD_LOG(NSCD_LOG_GETENT_CTX, NSCD_LOG_LEVEL_DEBUG)
514cb5caa98Sdjl (me, "putting back nsw state %p\n", gnctx->nsw_state);
515cb5caa98Sdjl
516cb5caa98Sdjl /* this nsw_state is no longer used for getent processing */
5176392794bSMichen Chang if (gnctx->nsw_state != NULL) {
518cb5caa98Sdjl gnctx->nsw_state->getent = 0;
519cb5caa98Sdjl _nscd_put_nsw_state(gnctx->nsw_state);
520cb5caa98Sdjl gnctx->nsw_state = NULL;
5216392794bSMichen Chang }
522cb5caa98Sdjl
52329836b19Smichen gnctx->aborted = 0;
52429836b19Smichen gnctx->in_use = 0;
5256392794bSMichen Chang gnctx->thr_id = (thread_t)-1;
526e37190e5Smichen _nscd_del_getent_ctx(gnctx, gnctx->cookie_num);
527cb5caa98Sdjl
528cb5caa98Sdjl _NSCD_LOG(NSCD_LOG_GETENT_CTX, NSCD_LOG_LEVEL_DEBUG)
529e37190e5Smichen (me, "ctx (%p, cookie # = %lld) removed from getent ctx DB\n",
530e37190e5Smichen gnctx, gnctx->cookie_num);
531cb5caa98Sdjl
5326392794bSMichen Chang gnctx->seq_num = 0;
5336392794bSMichen Chang gnctx->cookie_num = 0;
5346392794bSMichen Chang gnctx->pid = -1;
5356392794bSMichen Chang gnctx->thr_id = (thread_t)-1;
5366392794bSMichen Chang gnctx->n_src = 0;
5376392794bSMichen Chang gnctx->be = NULL;
5386392794bSMichen Chang
539cfed26cbSMichen Chang /* remove reference to the getent context base */
540cfed26cbSMichen Chang _nscd_release((nscd_acc_data_t *)base);
541cfed26cbSMichen Chang gnctx->base = NULL;
542cfed26cbSMichen Chang
543cb5caa98Sdjl _nscd_mutex_unlock((nscd_acc_data_t *)base);
544cb5caa98Sdjl }
545cb5caa98Sdjl
546cb5caa98Sdjl nscd_rc_t
_nscd_init_getent_ctx_base(int dbi,int lock)547cb5caa98Sdjl _nscd_init_getent_ctx_base(
548cb5caa98Sdjl int dbi,
549cb5caa98Sdjl int lock)
550cb5caa98Sdjl {
551cb5caa98Sdjl nscd_getent_ctx_base_t *base = NULL;
552cb5caa98Sdjl char *me = "_nscd_init_getent_ctx_base";
553cb5caa98Sdjl
554cb5caa98Sdjl if (lock)
555cb5caa98Sdjl (void) rw_rdlock(&nscd_getent_ctx_base_lock);
556cb5caa98Sdjl
557cb5caa98Sdjl base = (nscd_getent_ctx_base_t *)_nscd_alloc(
558cb5caa98Sdjl NSCD_DATA_GETENT_CTX_BASE,
559cb5caa98Sdjl sizeof (nscd_getent_ctx_base_t),
560cb5caa98Sdjl _nscd_free_getent_ctx_base,
561cb5caa98Sdjl NSCD_ALLOC_MUTEX | NSCD_ALLOC_COND);
562cb5caa98Sdjl
563cb5caa98Sdjl if (base == NULL) {
564cb5caa98Sdjl if (lock)
565cb5caa98Sdjl (void) rw_unlock(&nscd_getent_ctx_base_lock);
566cb5caa98Sdjl return (NSCD_NO_MEMORY);
567cb5caa98Sdjl }
568cb5caa98Sdjl _NSCD_LOG(NSCD_LOG_GETENT_CTX | NSCD_LOG_CONFIG, NSCD_LOG_LEVEL_DEBUG)
569cb5caa98Sdjl (me, "base %p allocated\n", base);
570cb5caa98Sdjl
571cb5caa98Sdjl /*
572cb5caa98Sdjl * initialize and activate the new getent_ctx base
573cb5caa98Sdjl */
574cb5caa98Sdjl base->dbi = dbi;
575cb5caa98Sdjl base->max_getent_ctx = NSCD_SW_CFG(dbi).max_getent_ctx_per_db;
576cb5caa98Sdjl nscd_getent_ctx_base[dbi] =
577cb5caa98Sdjl (nscd_getent_ctx_base_t *)_nscd_set(
578cb5caa98Sdjl (nscd_acc_data_t *)nscd_getent_ctx_base[dbi],
579cb5caa98Sdjl (nscd_acc_data_t *)base);
580cb5caa98Sdjl
581cb5caa98Sdjl if (lock)
582cb5caa98Sdjl (void) rw_unlock(&nscd_getent_ctx_base_lock);
583cb5caa98Sdjl
584cb5caa98Sdjl return (NSCD_SUCCESS);
585cb5caa98Sdjl }
586cb5caa98Sdjl
587cb5caa98Sdjl nscd_rc_t
_nscd_init_all_getent_ctx_base()588cb5caa98Sdjl _nscd_init_all_getent_ctx_base()
589cb5caa98Sdjl {
590cb5caa98Sdjl int i;
591cb5caa98Sdjl nscd_rc_t rc;
592cb5caa98Sdjl char *me = "_nscd_init_all_getent_ctx_base";
593cb5caa98Sdjl
594cb5caa98Sdjl (void) rw_wrlock(&nscd_getent_ctx_base_lock);
595cb5caa98Sdjl
596cb5caa98Sdjl for (i = 0; i < NSCD_NUM_DB; i++) {
597cb5caa98Sdjl
598cb5caa98Sdjl rc = _nscd_init_getent_ctx_base(i, 0);
599cb5caa98Sdjl
600cb5caa98Sdjl if (rc != NSCD_SUCCESS) {
601cb5caa98Sdjl (void) rw_unlock(&nscd_getent_ctx_base_lock);
602cb5caa98Sdjl return (rc);
603cb5caa98Sdjl }
604cb5caa98Sdjl }
605cb5caa98Sdjl
606cb5caa98Sdjl _NSCD_LOG(NSCD_LOG_GETENT_CTX | NSCD_LOG_CONFIG, NSCD_LOG_LEVEL_DEBUG)
607cb5caa98Sdjl (me, "all getent context base initialized\n");
608cb5caa98Sdjl
609cb5caa98Sdjl (void) rw_unlock(&nscd_getent_ctx_base_lock);
610cb5caa98Sdjl
611cb5caa98Sdjl return (NSCD_SUCCESS);
612cb5caa98Sdjl }
613cb5caa98Sdjl nscd_rc_t
_nscd_alloc_getent_ctx_base()614cb5caa98Sdjl _nscd_alloc_getent_ctx_base()
615cb5caa98Sdjl {
616cb5caa98Sdjl
617cb5caa98Sdjl (void) rw_wrlock(&nscd_getent_ctx_base_lock);
618cb5caa98Sdjl
619cb5caa98Sdjl nscd_getent_ctx_base = calloc(NSCD_NUM_DB,
620cb5caa98Sdjl sizeof (nscd_getent_ctx_base_t *));
621cb5caa98Sdjl if (nscd_getent_ctx_base == NULL) {
622cb5caa98Sdjl (void) rw_unlock(&nscd_getent_ctx_base_lock);
623cb5caa98Sdjl return (NSCD_NO_MEMORY);
624cb5caa98Sdjl }
625cb5caa98Sdjl
626cb5caa98Sdjl (void) rw_unlock(&nscd_getent_ctx_base_lock);
627cb5caa98Sdjl
628cb5caa98Sdjl return (NSCD_SUCCESS);
629cb5caa98Sdjl }
630cb5caa98Sdjl
631cb5caa98Sdjl static int
process_exited(pid_t pid)632cb5caa98Sdjl process_exited(pid_t pid)
633cb5caa98Sdjl {
634cb5caa98Sdjl char pname[PATH_MAX];
635cb5caa98Sdjl int fd;
636cb5caa98Sdjl
637cb5caa98Sdjl (void) snprintf(pname, sizeof (pname), "/proc/%d/psinfo", pid);
638cb5caa98Sdjl if ((fd = open(pname, O_RDONLY)) == -1)
639cb5caa98Sdjl return (1);
640cb5caa98Sdjl else {
641cb5caa98Sdjl (void) close(fd);
642cb5caa98Sdjl return (0);
643cb5caa98Sdjl }
644cb5caa98Sdjl }
645cb5caa98Sdjl
646cb5caa98Sdjl /*
647cb5caa98Sdjl * FUNCTION: reclaim_getent_ctx
648cb5caa98Sdjl */
649cb5caa98Sdjl /*ARGSUSED*/
650*9e293969SRichard Lowe static void * __NORETURN
reclaim_getent_ctx(void * arg)651cb5caa98Sdjl reclaim_getent_ctx(void *arg)
652cb5caa98Sdjl {
653cb5caa98Sdjl void *cookie = NULL;
654cb5caa98Sdjl nscd_db_entry_t *ep;
655cb5caa98Sdjl nscd_getent_ctx_t *ctx;
656cb5caa98Sdjl nscd_getent_context_t *gctx, *c;
657cb5caa98Sdjl nscd_getent_context_t *first = NULL, *last = NULL;
6586392794bSMichen Chang nss_getent_t nssctx = { 0 };
659cb5caa98Sdjl char *me = "reclaim_getent_ctx";
660cb5caa98Sdjl
661cb5caa98Sdjl /*CONSTCOND*/
662cb5caa98Sdjl while (1) {
663cb5caa98Sdjl
6649f590749Smichen (void) sleep(60);
6659f590749Smichen
666cb5caa98Sdjl (void) rw_rdlock(&getent_ctxDB_rwlock);
667cb5caa98Sdjl
668cb5caa98Sdjl for (ep = _nscd_walk_db(getent_ctxDB, &cookie); ep != NULL;
669cb5caa98Sdjl ep = _nscd_walk_db(getent_ctxDB, &cookie)) {
670cb5caa98Sdjl
671cb5caa98Sdjl ctx = (nscd_getent_ctx_t *)*(ep->data_array);
672cb5caa98Sdjl
673cb5caa98Sdjl gctx = ctx->ptr;
674cb5caa98Sdjl
675cb5caa98Sdjl /*
676cb5caa98Sdjl * if the client process, which did the setent,
677cb5caa98Sdjl * exited, add the context to the orphan list
678cb5caa98Sdjl */
679cb5caa98Sdjl if (gctx->pid != -1 && process_exited(gctx->pid)) {
680cb5caa98Sdjl
681cb5caa98Sdjl _NSCD_LOG(NSCD_LOG_GETENT_CTX,
682cb5caa98Sdjl NSCD_LOG_LEVEL_DEBUG)
683cb5caa98Sdjl (me, "process %d exited, "
684cb5caa98Sdjl "getent context = %p, "
685e37190e5Smichen "db index = %d, cookie # = %lld, "
686cb5caa98Sdjl "sequence # = %lld\n",
687cb5caa98Sdjl gctx->pid, gctx, gctx->dbi,
688e37190e5Smichen gctx->cookie_num, gctx->seq_num);
689cb5caa98Sdjl
690cb5caa98Sdjl if (first != NULL) {
6916392794bSMichen Chang /* add to list if not in already */
6926392794bSMichen Chang for (c = first; c != NULL;
6936392794bSMichen Chang c = c->next_to_reclaim) {
6946392794bSMichen Chang if (gctx == c)
6956392794bSMichen Chang break;
6966392794bSMichen Chang }
6976392794bSMichen Chang if (c == NULL) {
6986392794bSMichen Chang last->next_to_reclaim = gctx;
699cb5caa98Sdjl last = gctx;
7006392794bSMichen Chang }
701cb5caa98Sdjl } else {
702cb5caa98Sdjl first = gctx;
703cb5caa98Sdjl last = gctx;
704cb5caa98Sdjl }
705cb5caa98Sdjl }
706cb5caa98Sdjl }
707cb5caa98Sdjl
708cb5caa98Sdjl (void) rw_unlock(&getent_ctxDB_rwlock);
709cb5caa98Sdjl
710cb5caa98Sdjl
711cb5caa98Sdjl /*
71229836b19Smichen * return all the orphan getent contexts to the pool if not
71329836b19Smichen * in use
714cb5caa98Sdjl */
715cb5caa98Sdjl for (gctx = first; gctx; ) {
7166392794bSMichen Chang int in_use, num_reclaim_check;
7176392794bSMichen Chang
7186392794bSMichen Chang c = gctx->next_to_reclaim;
7196392794bSMichen Chang gctx->next_to_reclaim = NULL;
72029836b19Smichen gctx->aborted = 1;
7216392794bSMichen Chang
72229836b19Smichen (void) mutex_lock(&gctx->getent_mutex);
7236392794bSMichen Chang num_reclaim_check = gctx->num_reclaim_check++;
7246392794bSMichen Chang if (num_reclaim_check > 1)
7256392794bSMichen Chang gctx->in_use = 0;
72629836b19Smichen in_use = gctx->in_use;
72729836b19Smichen (void) mutex_unlock(&gctx->getent_mutex);
7286392794bSMichen Chang
7296392794bSMichen Chang if (in_use == 0) {
7306392794bSMichen Chang _NSCD_LOG(NSCD_LOG_GETENT_CTX,
7316392794bSMichen Chang NSCD_LOG_LEVEL_DEBUG)
7326392794bSMichen Chang (me, "process %d exited, "
7336392794bSMichen Chang "freeing getent context = %p\n",
7346392794bSMichen Chang gctx->pid, gctx);
7356392794bSMichen Chang nssctx.ctx = (struct nss_getent_context *)gctx;
7366392794bSMichen Chang nss_endent(NULL, NULL, &nssctx);
73729836b19Smichen }
738cb5caa98Sdjl gctx = c;
739cb5caa98Sdjl }
740cb5caa98Sdjl first = last = NULL;
741cb5caa98Sdjl }
742cb5caa98Sdjl /*NOTREACHED*/
743cb5caa98Sdjl /*LINTED E_FUNC_HAS_NO_RETURN_STMT*/
744cb5caa98Sdjl }
745cb5caa98Sdjl
746cb5caa98Sdjl static nscd_rc_t
_nscd_init_getent_ctx_monitor()747cb5caa98Sdjl _nscd_init_getent_ctx_monitor() {
748cb5caa98Sdjl
749cb5caa98Sdjl int errnum;
750cb5caa98Sdjl char *me = "_nscd_init_getent_ctx_monitor";
751cb5caa98Sdjl
752cb5caa98Sdjl _NSCD_LOG(NSCD_LOG_GETENT_CTX, NSCD_LOG_LEVEL_DEBUG)
753cb5caa98Sdjl (me, "initializing the getent context monitor\n");
754cb5caa98Sdjl
755cb5caa98Sdjl /*
756cb5caa98Sdjl * the forker nscd does not process getent requests
757cb5caa98Sdjl * so no need to monitor orphan getent contexts
758cb5caa98Sdjl */
759cb5caa98Sdjl if (_whoami == NSCD_FORKER)
760cb5caa98Sdjl return (NSCD_SUCCESS);
761cb5caa98Sdjl
762cb5caa98Sdjl /*
763cb5caa98Sdjl * start a thread to reclaim unused getent contexts
764cb5caa98Sdjl */
765cb5caa98Sdjl if (thr_create(NULL, NULL, reclaim_getent_ctx,
766cb5caa98Sdjl NULL, THR_DETACHED, NULL) != 0) {
767cb5caa98Sdjl errnum = errno;
768cb5caa98Sdjl _NSCD_LOG(NSCD_LOG_GETENT_CTX, NSCD_LOG_LEVEL_ERROR)
769cb5caa98Sdjl (me, "thr_create: %s\n", strerror(errnum));
770cb5caa98Sdjl return (NSCD_THREAD_CREATE_ERROR);
771cb5caa98Sdjl }
772cb5caa98Sdjl
773cb5caa98Sdjl return (NSCD_SUCCESS);
774cb5caa98Sdjl }
775