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