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 /*
22d2ba247cSmichen * Copyright 2008 Sun Microsystems, Inc. All rights reserved.
23cb5caa98Sdjl * Use is subject to license terms.
24ab618543SJohn Levon *
25ab618543SJohn Levon * Copyright 2018 Joyent, Inc.
26cb5caa98Sdjl */
27cb5caa98Sdjl
28cb5caa98Sdjl #include <stdlib.h>
29cb5caa98Sdjl #include <libscf.h>
30cb5caa98Sdjl #include <string.h>
31cb5caa98Sdjl #include "nscd_switch.h"
32cb5caa98Sdjl #include "nscd_log.h"
33cb5caa98Sdjl #include "nscd_door.h"
34cb5caa98Sdjl
35cb5caa98Sdjl extern int _whoami;
36cb5caa98Sdjl
37cb5caa98Sdjl /*
38cb5caa98Sdjl * Service states monitored by nscd. Protected by
39cb5caa98Sdjl * readers/writer lock nscd_smf_service_state_lock
40cb5caa98Sdjl */
41cb5caa98Sdjl nscd_smf_state_t *nscd_smf_service_state;
42cb5caa98Sdjl static rwlock_t nscd_smf_service_state_lock = DEFAULTRWLOCK;
43cb5caa98Sdjl /*
44cb5caa98Sdjl * init service state table
45cb5caa98Sdjl */
46cb5caa98Sdjl nscd_rc_t
_nscd_alloc_service_state_table()47cb5caa98Sdjl _nscd_alloc_service_state_table()
48cb5caa98Sdjl {
49cb5caa98Sdjl int i;
50cb5caa98Sdjl
51cb5caa98Sdjl nscd_smf_service_state = calloc(NSCD_NUM_SMF_FMRI,
52d2ba247cSmichen sizeof (nscd_smf_state_t));
53cb5caa98Sdjl
54cb5caa98Sdjl if (nscd_smf_service_state == NULL)
55cb5caa98Sdjl return (NSCD_NO_MEMORY);
56cb5caa98Sdjl
57cb5caa98Sdjl for (i = 1; i < NSCD_NUM_SMF_FMRI; i++)
58cb5caa98Sdjl NSCD_SMF_SVC_STATE(i) = NSCD_SVC_STATE_UNINITED;
59cb5caa98Sdjl
60cb5caa98Sdjl return (NSCD_SUCCESS);
61cb5caa98Sdjl }
62cb5caa98Sdjl
63cb5caa98Sdjl static int
query_smf_state(int srci)64cb5caa98Sdjl query_smf_state(int srci)
65cb5caa98Sdjl {
66cb5caa98Sdjl
67cb5caa98Sdjl int ret = NSCD_SVC_STATE_UNINITED;
68cb5caa98Sdjl char *state = NULL;
69cb5caa98Sdjl char *me = "query_smf_state";
70cb5caa98Sdjl
71cb5caa98Sdjl state = smf_get_state(NSCD_SMF_SVC_FMRI(srci));
72cb5caa98Sdjl if (state == NULL)
73cb5caa98Sdjl return (ret);
74cb5caa98Sdjl
75cb5caa98Sdjl _NSCD_LOG(NSCD_LOG_SMF_MONITOR, NSCD_LOG_LEVEL_DEBUG)
76cb5caa98Sdjl (me, "%s -- %s\n", state, NSCD_SMF_SVC_FMRI(srci));
77cb5caa98Sdjl
78cb5caa98Sdjl (void) rw_wrlock(&nscd_smf_service_state_lock);
79cb5caa98Sdjl
80cb5caa98Sdjl if (nscd_smf_service_state[srci].src_name == NULL)
81cb5caa98Sdjl nscd_smf_service_state[srci].src_name =
82d2ba247cSmichen NSCD_NSW_SRC_NAME(srci);
83cb5caa98Sdjl
84cb5caa98Sdjl if (strcmp(state, SCF_STATE_STRING_UNINIT) == 0)
85cb5caa98Sdjl NSCD_SMF_SVC_STATE(srci) = SCF_STATE_UNINIT;
86cb5caa98Sdjl else if (strcmp(state, SCF_STATE_STRING_MAINT) == 0)
87cb5caa98Sdjl NSCD_SMF_SVC_STATE(srci) = SCF_STATE_MAINT;
88cb5caa98Sdjl else if (strcmp(state, SCF_STATE_STRING_OFFLINE) == 0)
89cb5caa98Sdjl NSCD_SMF_SVC_STATE(srci) = SCF_STATE_OFFLINE;
90cb5caa98Sdjl else if (strcmp(state, SCF_STATE_STRING_DISABLED) == 0)
91cb5caa98Sdjl NSCD_SMF_SVC_STATE(srci) = SCF_STATE_DISABLED;
92cb5caa98Sdjl else if (strcmp(state, SCF_STATE_STRING_ONLINE) == 0)
93cb5caa98Sdjl NSCD_SMF_SVC_STATE(srci) = SCF_STATE_ONLINE;
94cb5caa98Sdjl else if (strcmp(state, SCF_STATE_STRING_DEGRADED) == 0)
95cb5caa98Sdjl NSCD_SMF_SVC_STATE(srci) = SCF_STATE_DEGRADED;
96cb5caa98Sdjl
97cb5caa98Sdjl ret = NSCD_SMF_SVC_STATE(srci);
98cb5caa98Sdjl (void) rw_unlock(&nscd_smf_service_state_lock);
99cb5caa98Sdjl
100cb5caa98Sdjl free(state);
101cb5caa98Sdjl return (ret);
102cb5caa98Sdjl }
103cb5caa98Sdjl
104cb5caa98Sdjl /* ARGSUSED */
105cb5caa98Sdjl static void *
set_smf_state(void * arg)106cb5caa98Sdjl set_smf_state(void *arg)
107cb5caa98Sdjl {
108cb5caa98Sdjl
109cb5caa98Sdjl int i;
110cb5caa98Sdjl int st;
111cb5caa98Sdjl
112ab618543SJohn Levon (void) thr_setname(thr_self(), "set_smf_state");
113ab618543SJohn Levon
114cb5caa98Sdjl /*
115cb5caa98Sdjl * the forker nscd needs not monitor the state
116cb5caa98Sdjl * of the client services
117cb5caa98Sdjl */
118cb5caa98Sdjl if (_whoami == NSCD_FORKER)
119cb5caa98Sdjl thr_exit(0);
120cb5caa98Sdjl
121cb5caa98Sdjl /*CONSTCOND*/
122cb5caa98Sdjl while (1) {
123cb5caa98Sdjl
124cb5caa98Sdjl /* skip the first service which is nscd */
125cb5caa98Sdjl for (i = 1; i < NSCD_NUM_SMF_FMRI; i++) {
126cb5caa98Sdjl st = query_smf_state(i);
127cb5caa98Sdjl if (st == NSCD_SVC_STATE_UNINITED)
128cb5caa98Sdjl break;
129cb5caa98Sdjl }
130cb5caa98Sdjl
131cb5caa98Sdjl (void) sleep(NSCD_SW_CFG_G.check_smf_state_interval_g);
132cb5caa98Sdjl }
133cb5caa98Sdjl /* NOTREACHED */
134cb5caa98Sdjl /*LINTED E_FUNC_HAS_NO_RETURN_STMT*/
135cb5caa98Sdjl }
136cb5caa98Sdjl
137cb5caa98Sdjl nscd_rc_t
_nscd_init_smf_monitor(void)138*fa845c5dSToomas Soome _nscd_init_smf_monitor(void)
139*fa845c5dSToomas Soome {
140cb5caa98Sdjl
141cb5caa98Sdjl int errnum;
142cb5caa98Sdjl char *me = "_nscd_init_smf_monitor";
143cb5caa98Sdjl
144cb5caa98Sdjl _NSCD_LOG(NSCD_LOG_SMF_MONITOR, NSCD_LOG_LEVEL_DEBUG)
145cb5caa98Sdjl (me, "initializing the smf monitor\n");
146cb5caa98Sdjl
147cb5caa98Sdjl /*
148cb5caa98Sdjl * start a thread to check the state of the client services
149cb5caa98Sdjl */
150*fa845c5dSToomas Soome if (thr_create(NULL, 0, set_smf_state,
151*fa845c5dSToomas Soome NULL, THR_DETACHED, NULL) != 0) {
152cb5caa98Sdjl errnum = errno;
153cb5caa98Sdjl _NSCD_LOG(NSCD_LOG_SMF_MONITOR, NSCD_LOG_LEVEL_ERROR)
154cb5caa98Sdjl (me, "thr_create: %s\n", strerror(errnum));
155cb5caa98Sdjl return (NSCD_THREAD_CREATE_ERROR);
156cb5caa98Sdjl }
157cb5caa98Sdjl
158cb5caa98Sdjl return (NSCD_SUCCESS);
159cb5caa98Sdjl }
160cb5caa98Sdjl
161cb5caa98Sdjl int
_nscd_get_smf_state(int srci,int dbi,int recheck)162cb5caa98Sdjl _nscd_get_smf_state(int srci, int dbi, int recheck)
163cb5caa98Sdjl {
164cb5caa98Sdjl int s;
165cb5caa98Sdjl char *n;
166cb5caa98Sdjl
167cb5caa98Sdjl n = NSCD_NSW_SRC_NAME(srci);
168cb5caa98Sdjl
169cb5caa98Sdjl /* the files, compat, and dns backends are always available */
1702b4a7802SBaban Kenkre if ((*n == 'f' || *n == 'c' || *n == 'd' || *n == 'a') &&
171d2ba247cSmichen (strcmp(NSCD_NSW_SRC_NAME(srci), "files") == 0 ||
172d2ba247cSmichen strcmp(NSCD_NSW_SRC_NAME(srci), "compat") == 0 ||
1732b4a7802SBaban Kenkre strcmp(NSCD_NSW_SRC_NAME(srci), "ad") == 0 ||
174d2ba247cSmichen strcmp(NSCD_NSW_SRC_NAME(srci), "dns") == 0)) {
175cb5caa98Sdjl return (SCF_STATE_ONLINE);
176cb5caa98Sdjl }
177cb5caa98Sdjl
178cb5caa98Sdjl /*
179cb5caa98Sdjl * for the printer database and user backend, treat the
180cb5caa98Sdjl * backend as a unsupported one, as nscd can not access
181cb5caa98Sdjl * the home directory of the user
182cb5caa98Sdjl */
183cb5caa98Sdjl if (*n == 'u' && strcmp(NSCD_NSW_SRC_NAME(srci), "user") == 0) {
184cb5caa98Sdjl if (strcmp(NSCD_NSW_DB_NAME(dbi), NSS_DBNAM_PRINTERS) == 0)
185d2ba247cSmichen return (NSCD_SVC_STATE_UNSUPPORTED_SRC);
186cb5caa98Sdjl else
187cb5caa98Sdjl return (SCF_STATE_ONLINE);
188cb5caa98Sdjl }
189cb5caa98Sdjl
190cb5caa98Sdjl /*
191d2ba247cSmichen * Foreign backend is not supported by nscd unless
192d2ba247cSmichen * the backend supports the nss2 interface (global
193d2ba247cSmichen * symbol _nss_<backname name>_version is present),
194cb5caa98Sdjl * tell the switch engine to return NSS_TRYLOCAL
195d2ba247cSmichen * if needed via rc NSCD_SVC_STATE_FOREIGN_SRC.
196cb5caa98Sdjl */
197cb5caa98Sdjl if (srci >= _nscd_cfg_num_nsw_src)
198d2ba247cSmichen return (NSCD_SVC_STATE_FOREIGN_SRC);
199cb5caa98Sdjl
200cb5caa98Sdjl if (recheck == 1)
201cb5caa98Sdjl return (query_smf_state(srci));
202cb5caa98Sdjl
203cb5caa98Sdjl (void) rw_rdlock(&nscd_smf_service_state_lock);
204cb5caa98Sdjl s = NSCD_SMF_SVC_STATE(srci);
205cb5caa98Sdjl (void) rw_unlock(&nscd_smf_service_state_lock);
206cb5caa98Sdjl
207cb5caa98Sdjl /*
208cb5caa98Sdjl * if the state has been queried at least once but is
209cb5caa98Sdjl * still not online, query one more time
210cb5caa98Sdjl */
211cb5caa98Sdjl if (s != NSCD_SVC_STATE_UNINITED && s < SCF_STATE_ONLINE)
212cb5caa98Sdjl s = query_smf_state(srci);
213cb5caa98Sdjl
214cb5caa98Sdjl return (s);
215cb5caa98Sdjl }
216