xref: /titanic_41/usr/src/lib/libmapid/common/mapid.c (revision 28cdc3d776761766afeb198769d1b70ed7e0f2e1)
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 2006 Sun Microsystems, Inc.  All rights reserved.
23  * Use is subject to license terms.
24  */
25 
26 #pragma ident	"%Z%%M%	%I%	%E% SMI"
27 
28 /*
29  * PSARC/2004/154 nfsmapid DNS enhancements implementation.
30  *
31  * As per RFC 3530, file owner and group attributes in version 4 of the
32  * NFS protocol are no longer exchanged between client and server as 32
33  * bit integral values. Instead, owner and group file attributes are
34  * exchanged between client and server as UTF8 strings of form
35  *
36  *      'user@domain'		(ie. "joeblow@central.sun.com")
37  *      'group@domain'		(ie. "staff@central.sun.com")
38  *
39  * This NFSv4 feature is far beyond anything NFSv2/v3 ever provided, as
40  * being able to describe a user with a unique string identifier provides
41  * a much more powerful and administrative friendly way of dealing with
42  * overlaps in the uid/gid number spaces. That notwithstanding, dealing
43  * with issues of correctly mapping user and group ownership in a cross-
44  * domain environment has proven a difficult problem to solve, since
45  * dealing with different permutations of client naming configurations
46  * (ie. NIS only, LDAP only, etc.) have bloated the problem. Thus, users
47  * utilizing clients and servers that have the 'domain' portion of the
48  * UTF8 attribute string configured differently than its peer server and
49  * client accordingly, will experience watching their files owned by the
50  * 'nobody' user and group. This is due to the fact that the 'domain's
51  * don't match and the nfsmapid daemon treats the attribute strings as
52  * unknown user(s) or group(s) (even though the actual uid/gid's may exist
53  * in the executing daemon's system). Please refer to PSARC/2004/154 for
54  * further background and motivation for these enhancements.
55  *
56  * The latest implementation of the nfsmapid daemon relies on a DNS TXT
57  * record. The behavior of nfsmapid is to first use the NFSMAPID_DOMAIN
58  * configuration option in /etc/default/nfs. If the option has not been
59  * set, then the nfsmapid daemon queries the configured DNS domain server
60  * for the _nfsv4idmapdomain TXT record. If the record exists, then the
61  * record's value is used as the 'domain' portion of the UTF8 attribute
62  * strings. If the TXT record has not been configured in the DNS server,
63  * then the daemon falls back to using the DNS domain name itself as the
64  * 'domain' portion of the attribute strings. Lastly, if the configured
65  * DNS server is unresponsive, the nfsmapid daemon falls back to using
66  * the DNS domain name as the 'domain' portion of the attribute strings,
67  * and fires up a query thread to keep contacting the DNS server until
68  * it responds with either a TXT record, or a lack thereof, in which
69  * case, nfsmapid just continues to utilize the DNS domain name.
70  */
71 #define	__LIBMAPID_IMPL
72 #include <nfs/mapid.h>
73 #pragma	init(_lib_init)
74 
75 /*
76  * DEBUG Only
77  * Decode any resolver errors and print out message to log
78  */
79 static int
80 resolv_error(void)
81 {
82 #ifndef	DEBUG
83 
84 	return (h_errno);
85 
86 #else	/* DEBUG */
87 
88 	static uint64_t	 msg_done[NS_ERRS] = {0};
89 
90 	switch (h_errno) {
91 	case NETDB_INTERNAL:
92 		syslog(LOG_ERR, EMSG_NETDB_INTERNAL, strerror(errno));
93 		break;
94 
95 	case HOST_NOT_FOUND:
96 		(void) rw_rdlock(&s_dns_impl_lock);
97 		msg_done[h_errno]++;
98 		if (!(msg_done[h_errno] % NFSMAPID_SLOG_RATE))
99 			syslog(LOG_ERR, EMSG_HOST_NOT_FOUND, s_dname);
100 		(void) rw_unlock(&s_dns_impl_lock);
101 		break;
102 
103 	case TRY_AGAIN:
104 		/*
105 		 * Nameserver is not responding.
106 		 * Try again after a given timeout.
107 		 */
108 		(void) rw_rdlock(&s_dns_impl_lock);
109 		msg_done[h_errno]++;
110 		if (!(msg_done[h_errno] % NFSMAPID_SLOG_RATE))
111 			syslog(LOG_ERR, EMSG_TRY_AGAIN, s_dname);
112 		(void) rw_unlock(&s_dns_impl_lock);
113 		break;
114 
115 	case NO_RECOVERY:
116 		/*
117 		 * This msg only really happens once, due
118 		 * to s_dns_disabled flag (see below)
119 		 */
120 		syslog(LOG_ERR, EMSG_NO_RECOVERY, hstrerror(h_errno));
121 		break;
122 
123 	case NO_DATA:
124 		/*
125 		 * No entries in the nameserver for
126 		 * the specific record or record type.
127 		 */
128 		(void) rw_rdlock(&s_dns_impl_lock);
129 		msg_done[h_errno]++;
130 		if (!(msg_done[h_errno] % NFSMAPID_SLOG_RATE))
131 			syslog(LOG_ERR, EMSG_NO_DATA, NFSMAPID_DNS_RR, s_dname);
132 		(void) rw_unlock(&s_dns_impl_lock);
133 		break;
134 
135 	case NETDB_SUCCESS:
136 	default:
137 		break;
138 	}
139 	return (h_errno);
140 
141 #endif	/* DEBUG */
142 }
143 
144 /*
145  * Reset the global state variables used for the TXT record.
146  * Having these values reset to zero helps nfsmapid confirm
147  * that a valid DNS TXT record was not found; in which case,
148  * it would fall back to using the configured DNS domain name.
149  *
150  * If a valid DNS TXT record _was_ found, but subsequent contact
151  * to the DNS server is somehow hindered, the previous DNS TXT
152  * RR value continues to be used. Thus, in such instances, we
153  * forego clearing the global config variables so nfsmapid can
154  * continue to use a valid DNS TXT RR while contact to the DNS
155  * server is reestablished.
156  */
157 static void
158 resolv_txt_reset(void)
159 {
160 	(void) rw_wrlock(&s_dns_impl_lock);
161 	bzero(s_txt_rr, sizeof (s_txt_rr));
162 	(void) rw_unlock(&s_dns_impl_lock);
163 
164 	(void) rw_wrlock(&s_dns_data_lock);
165 	if (!dns_txt_cached) {
166 		dns_txt_domain_len = 0;
167 		bzero(dns_txt_domain, DNAMEMAX);
168 	}
169 	(void) rw_unlock(&s_dns_data_lock);
170 }
171 
172 /*
173  * Initialize resolver and populate &s_res struct
174  *
175  * DNS Domain is saved off sysdns_domain in case we
176  * need to fall back to using the DNS domain name as
177  * the v4 attribute string domain.
178  */
179 static int
180 resolv_init(void)
181 {
182 	size_t			len;
183 	int			n;
184 	struct __res_state	res;
185 
186 	(void) mutex_lock(&s_res_lock);
187 	bzero(&s_res, sizeof (struct __res_state));
188 	n = h_errno = errno = 0;
189 	if ((n = res_ninit(&s_res)) < 0) {
190 		(void) mutex_unlock(&s_res_lock);
191 		(void) resolv_error();
192 		return (n);
193 	}
194 	res = s_res;
195 	(void) mutex_unlock(&s_res_lock);
196 
197 	len = strlen(res.defdname) + 1;
198 	(void) rw_wrlock(&s_dns_impl_lock);
199 	bzero(s_dname, sizeof (s_dname));
200 	(void) snprintf(s_dname, len, "%s", res.defdname);
201 	(void) rw_unlock(&s_dns_impl_lock);
202 
203 	(void) rw_wrlock(&s_dns_data_lock);
204 	(void) snprintf(sysdns_domain, len, "%s", res.defdname);
205 	(void) rw_unlock(&s_dns_data_lock);
206 
207 	return (0);
208 }
209 
210 /*
211  * Search criteria assumptions:
212  *
213  * The onus will fall on the sysadmins to correctly configure the TXT
214  * record in the DNS domain where the box currently resides in order
215  * for the record to be found. However, if they sysadmin chooses to
216  * add the 'search' key to /etc/resolv.conf, then resolv_search()
217  * _will_ traverse up the DNS tree as specified in the 'search' key.
218  * Otherwise, we'll default the domain to the DNS domain itself.
219  */
220 static int
221 resolv_search(void)
222 {
223 	int			len;
224 	ans_t			ans = {0};
225 	struct __res_state	res;
226 	int			type = T_TXT;
227 	int			class = C_IN;
228 
229 	(void) mutex_lock(&s_res_lock);
230 	res = s_res;
231 	(void) mutex_unlock(&s_res_lock);
232 
233 	/*
234 	 * Avoid holding locks across the res_nsearch() call to
235 	 * prevent stalling threads during network partitions.
236 	 */
237 	len = h_errno = errno = 0;
238 	if ((len = res_nsearch(&res, NFSMAPID_DNS_RR, class, type,
239 	    ans.buf, sizeof (ans))) < 0)
240 		return (resolv_error());
241 
242 	(void) rw_wrlock(&s_dns_impl_lock);
243 	s_ans = ans;
244 	s_anslen = len;
245 	(void) rw_unlock(&s_dns_impl_lock);
246 
247 	return (NETDB_SUCCESS);
248 }
249 
250 /*
251  * Skip one DNS record
252  */
253 static uchar_t  *
254 resolv_skip_rr(uchar_t *p, uchar_t *eom)
255 {
256 	int	t;
257 	int	dlen;
258 
259 	/*
260 	 * Skip compressed name
261 	 */
262 	errno = 0;
263 	if ((t = dn_skipname(p, eom)) < 0) {
264 #ifdef	DEBUG
265 		syslog(LOG_ERR, "%s", strerror(errno));
266 #endif
267 		return (NULL);
268 	}
269 
270 	/*
271 	 * Advance pointer and make sure
272 	 * we're still within the message
273 	 */
274 	p += t;
275 	if ((p + RRFIXEDSZ) > eom)
276 		return (NULL);
277 
278 	/*
279 	 * Now, just skip over the rr fields
280 	 */
281 	p += INT16SZ;	/* type */
282 	p += INT16SZ;	/* class */
283 	p += INT32SZ;	/* ttl */
284 	dlen = ns_get16(p);
285 	p += INT16SZ;
286 	p += dlen;	/* dlen */
287 	if (p > eom)
288 		return (NULL);
289 
290 	return (p);
291 }
292 
293 /*
294  * Process one TXT record.
295  *
296  * nfsmapid queries the DNS server for the specific _nfsv4idmapdomain
297  * TXT record. Thus, if the TXT record exists, the answer section of
298  * the DNS response carries the TXT record's value. Thus, we check that
299  * the value is indeed a valid domain and set the modular s_txt_rr
300  * global to the domain value.
301  */
302 static void
303 resolve_process_txt(uchar_t *p, int dlen)
304 {
305 	char		*rr_base = (char *)(p + 1);
306 	char		*rr_end = (char *)(p + dlen);
307 	size_t		 len = rr_end - rr_base;
308 #ifdef	DEBUG
309 	static uint64_t	 msg_done = 0;
310 #endif
311 	char		 tmp_txt_rr[DNAMEMAX];
312 
313 	if (len >= DNAMEMAX)
314 		return;		/* process next TXT RR */
315 
316 	/*
317 	 * make sure we have a clean buf since
318 	 * we may've processed several TXT rr's
319 	 */
320 	(void) rw_wrlock(&s_dns_impl_lock);
321 	bzero(s_txt_rr, sizeof (s_txt_rr));
322 	(void) rw_unlock(&s_dns_impl_lock);
323 
324 	(void) strncpy(tmp_txt_rr, rr_base, len);
325 	tmp_txt_rr[len] = '\0';
326 
327 	/*
328 	 * If there is a record and it's a valid domain, we're done.
329 	 */
330 	if (rr_base[0] != '\0' && mapid_stdchk_domain(tmp_txt_rr) > 0) {
331 		(void) rw_wrlock(&s_dns_impl_lock);
332 		(void) strncpy(s_txt_rr, rr_base, len);
333 		(void) rw_unlock(&s_dns_impl_lock);
334 #ifdef	DEBUG
335 		syslog(LOG_ERR, "TXT (Rec):\t%s", s_txt_rr);
336 
337 	} else if (!(msg_done++ % NFSMAPID_SLOG_RATE)) {
338 		/*
339 		 * Otherwise, log the error
340 		 */
341 		(void) rw_rdlock(&s_dns_impl_lock);
342 		syslog(LOG_ERR, EMSG_DNS_RR_INVAL, NFSMAPID_DNS_RR, s_dname);
343 		(void) rw_unlock(&s_dns_impl_lock);
344 #endif
345 	}
346 }
347 
348 /*
349  * Decode any answer received from the DNS server. This interface is
350  * capable of much more than just decoding TXT records. We maintain
351  * focus on TXT rr's for now, but this will probably change once we
352  * get the IETF approved application specific DNS RR.
353  *
354  * Here's an example of the TXT record we're decoding (as would appear
355  * in the DNS zone file):
356  *
357  *            _nfsv4idmapdomain    IN    TXT    "sun.com"
358  *
359  * Once the IETF application specific DNS RR is granted, we should only
360  * be changing the record flavor, but all should pretty much stay the
361  * same.
362  */
363 static void
364 resolv_decode(void)
365 {
366 	uchar_t		*buf;
367 	HEADER		*hp;
368 	uchar_t		 name[DNAMEMAX];
369 	uchar_t		*eom;
370 	uchar_t		*p;
371 	int		 n;
372 	uint_t		 qd_cnt;
373 	uint_t		 an_cnt;
374 	uint_t		 ns_cnt;
375 	uint_t		 ar_cnt;
376 	uint_t		 cnt;
377 	uint_t		 type;
378 	int		 dlen;
379 	ans_t		 answer = {0};
380 	int		 answer_len = 0;
381 
382 	/*
383 	 * Check the HEADER for any signs of errors
384 	 * and extract the answer counts for later.
385 	 */
386 	(void) rw_rdlock(&s_dns_impl_lock);
387 	answer = s_ans;
388 	answer_len = s_anslen;
389 	(void) rw_unlock(&s_dns_impl_lock);
390 
391 	buf = (uchar_t *)&answer.buf;
392 	hp = (HEADER *)&answer.hdr;
393 	eom = (uchar_t *)(buf + answer_len);
394 	if (hp->rcode !=  NOERROR) {
395 #ifdef	DEBUG
396 		syslog(LOG_ERR, "errno: %s", strerror(errno));
397 		syslog(LOG_ERR, "h_errno: %s", hstrerror(h_errno));
398 #endif
399 		return;
400 	}
401 	qd_cnt = ntohs(hp->qdcount);
402 	an_cnt = ntohs(hp->ancount);
403 	ns_cnt = ntohs(hp->nscount);
404 	ar_cnt = ntohs(hp->arcount);
405 
406 	/*
407 	 * skip query entries
408 	 */
409 	p = (uchar_t *)(buf + HFIXEDSZ);
410 	errno = 0;
411 	while (qd_cnt-- > 0) {
412 		n = dn_skipname(p, eom);
413 		if (n < 0) {
414 #ifdef	DEBUG
415 			syslog(LOG_ERR, "%s", strerror(errno));
416 #endif
417 			return;
418 		}
419 		p += n;
420 		p += INT16SZ;	/* type */
421 		p += INT16SZ;	/* class */
422 	}
423 
424 #ifdef	DEBUG
425 	/*
426 	 * If debugging... print query only once.
427 	 * NOTE: Don't advance pointer... this is done
428 	 *	 in while() loop on a per record basis !
429 	 */
430 	n = h_errno = errno = 0;
431 	n = dn_expand(buf, eom, p, (char *)name, sizeof (name));
432 	if (n < 0) {
433 		(void) resolv_error();
434 		return;
435 	}
436 	syslog(LOG_ERR, "Query:\t\t%-30s", name);
437 #endif
438 
439 	/*
440 	 * Process actual answer(s).
441 	 */
442 	cnt = an_cnt;
443 	while (cnt-- > 0 && p < eom) {
444 		/* skip the name field */
445 		n = dn_expand(buf, eom, p, (char *)name, sizeof (name));
446 		if (n < 0) {
447 			(void) resolv_error();
448 			return;
449 		}
450 		p += n;
451 
452 		if ((p + 3 * INT16SZ + INT32SZ) > eom)
453 			return;
454 
455 		type = ns_get16(p);
456 		p += INT16SZ;
457 		p += INT16SZ + INT32SZ;	/* skip class & ttl */
458 		dlen = ns_get16(p);
459 		p += INT16SZ;
460 
461 		if ((p + dlen) > eom)
462 			return;
463 
464 		switch (type) {
465 			case T_TXT:
466 				resolve_process_txt(p, dlen);
467 				break;
468 
469 			default:
470 				/*
471 				 * Advance to next answer record for any
472 				 * other record types. Again, this will
473 				 * probably change (see block comment).
474 				 */
475 				p += dlen;
476 				break;
477 		}
478 	}
479 
480 	/*
481 	 * Skip name server and additional records for now.
482 	 */
483 	cnt = ns_cnt + ar_cnt;
484 	if (cnt > 0) {
485 		while (--cnt != 0 && p < eom) {
486 			p = resolv_skip_rr(p, eom);
487 			if (p == NULL)
488 				return;
489 		}
490 	}
491 }
492 
493 /*
494  * If a valid TXT record entry exists, s_txt_rr contains the domain
495  * value (as set in resolv_process_txt) and we extract the value into
496  * dns_txt_domain (the exported global). If there was _no_ valid TXT
497  * entry, we simply return and check_domain() will default to the
498  * DNS domain since we did resolv_txt_reset() first.
499  */
500 static void
501 resolv_get_txt_data()
502 {
503 	(void) rw_rdlock(&s_dns_impl_lock);
504 	if (s_txt_rr[0] != '\0') {
505 		(void) rw_wrlock(&s_dns_data_lock);
506 		(void) snprintf(dns_txt_domain, strlen(s_txt_rr) + 1, "%s",
507 								s_txt_rr);
508 		dns_txt_domain_len = strlen(dns_txt_domain);
509 		dns_txt_cached = 1;
510 		(void) rw_unlock(&s_dns_data_lock);
511 	}
512 	(void) rw_unlock(&s_dns_impl_lock);
513 }
514 
515 static void
516 domain_sync(cb_t *argp, char *dname)
517 {
518 	int	dlen = 0;
519 	void	*(*fcn)(void *) = NULL;
520 	int	sighup = 0;
521 	int	domchg = 0;
522 
523 	/*
524 	 * Make sure values passed are sane and initialize accordingly.
525 	 */
526 	if (dname != NULL)
527 		dlen = strlen(dname);
528 	if (argp) {
529 		if (argp->fcn)
530 			fcn = argp->fcn;
531 		if (argp->signal)
532 			sighup = argp->signal;
533 	}
534 
535 	/*
536 	 * Update the library's mapid_domain variable if 'dname' is different.
537 	 */
538 	if (dlen != 0 && strncasecmp(dname, mapid_domain, NS_MAXCDNAME)) {
539 		(void) rw_wrlock(&mapid_domain_lock);
540 		(void) strncpy(mapid_domain, dname, NS_MAXCDNAME);
541 		mapid_domain_len = dlen;
542 		(void) rw_unlock(&mapid_domain_lock);
543 		domchg++;
544 	}
545 
546 	/*
547 	 * If the caller gave us a valid callback routine, we
548 	 * instantiate it to announce the domain change, but
549 	 * only if either the domain changed _or_ the caller
550 	 * was issued a SIGHUP.
551 	 */
552 	if (fcn != NULL && (sighup || domchg))
553 		(void) fcn((void *)mapid_domain);
554 }
555 
556 /*
557  * Thread to keep pinging  DNS  server for  TXT  record if nfsmapid's
558  * initial attempt at contact with server failed. We could potentially
559  * have a substantial number of NFSv4 clients and having all of them
560  * hammering on an already unresponsive DNS server would not help
561  * things. So, we limit the number of live query threads to at most
562  * 1 at any one time to keep things from getting out of hand.
563  */
564 /* ARGSUSED */
565 static void *
566 resolv_query_thread(void *arg)
567 {
568 	unsigned int	 nap_time;
569 
570 #ifdef	DEBUG
571 	char		*whoami = "query_thread";
572 
573 	syslog(LOG_ERR, "%s active !", whoami);
574 #endif
575 	(void) rw_rdlock(&s_dns_impl_lock);
576 	nap_time = s_dns_tout;
577 	(void) rw_unlock(&s_dns_impl_lock);
578 
579 	for (;;) {
580 		(void) sleep(nap_time);
581 
582 		resolv_txt_reset();
583 		(void) resolv_init();
584 		switch (resolv_search()) {
585 		case NETDB_SUCCESS:
586 			resolv_decode();
587 			resolv_get_txt_data();
588 
589 			/*
590 			 * This is a bit different than what we
591 			 * do in get_dns_txt_domain(), where we
592 			 * simply return and let the caller
593 			 * access dns_txt_domain directly.
594 			 *
595 			 * Here we invoke the callback routine
596 			 * provided by the caller to the
597 			 * mapid_reeval_domain() interface via
598 			 * the cb_t's fcn param.
599 			 */
600 			domain_sync((cb_t *)arg, dns_txt_domain);
601 			goto thr_okay;
602 
603 		case NO_DATA:
604 			/*
605 			 * DNS is up now, but does not have
606 			 * the NFSV4IDMAPDOMAIN TXT record.
607 			 */
608 #ifdef	DEBUG
609 			syslog(LOG_ERR, "%s: DNS has no TXT Record", whoami);
610 #endif
611 			goto thr_reset;
612 
613 		case NO_RECOVERY:
614 			/*
615 			 * Non-Recoverable error occurred. No sense
616 			 * in keep pinging the DNS server at this
617 			 * point, so we disable any further contact.
618 			 */
619 #ifdef	DEBUG
620 			syslog(LOG_ERR, EMSG_DNS_DISABLE, whoami);
621 #endif
622 			(void) rw_wrlock(&s_dns_impl_lock);
623 			s_dns_disabled = TRUE;
624 			(void) rw_unlock(&s_dns_impl_lock);
625 			goto thr_reset;
626 
627 		case HOST_NOT_FOUND:
628 			/*
629 			 * Authoritative NS not responding...
630 			 * keep trying for non-authoritative reply
631 			 */
632 			/*FALLTHROUGH*/
633 
634 		case TRY_AGAIN:
635 			/* keep trying */
636 #ifdef	DEBUG
637 			syslog(LOG_ERR, "%s: retrying...", whoami);
638 #endif
639 			break;
640 
641 		case NETDB_INTERNAL:
642 		default:
643 #ifdef	DEBUG
644 			syslog(LOG_ERR, "%s: Internal resolver error: %s",
645 			    whoami, strerror(errno));
646 #endif
647 			goto thr_reset;
648 		}
649 	}
650 thr_reset:
651 	(void) rw_wrlock(&s_dns_data_lock);
652 	dns_txt_cached = 0;
653 	(void) rw_unlock(&s_dns_data_lock);
654 	resolv_txt_reset();
655 
656 thr_okay:
657 	/* mark thread as done */
658 	(void) rw_wrlock(&s_dns_impl_lock);
659 	s_dns_qthr_created = FALSE;
660 	(void) rw_unlock(&s_dns_impl_lock);
661 
662 	(void) thr_exit(NULL);
663 	/*NOTREACHED*/
664 	return (NULL);
665 }
666 
667 /*
668  * nfsmapid's interface into the resolver for getting the TXT record.
669  *
670  * Key concepts:
671  *
672  * o If the DNS server is available and the TXT record is found, we
673  *   simply decode the output and fill the exported dns_txt_domain
674  *   global, so our caller can configure the daemon appropriately.
675  *
676  * o If the TXT record is not found, then having done resolv_txt_reset()
677  *   first will allow our caller to recognize that the exported globals
678  *   are empty and thus configure nfsmapid to use the default DNS domain.
679  *
680  * o Having no /etc/resolv.conf file is pretty much a show stopper, since
681  *   there is no name server address information. We return since we've
682  *   already have reset the TXT global state.
683  *
684  * o If a previous call to the DNS server resulted in an unrecoverable
685  *   error, then we disable further contact to the DNS server and return.
686  *   Having the TXT global state already reset guarantees that our caller
687  *   will fall back to the right configuration.
688  *
689  * o Query thread creation is throttled by s_dns_qthr_created. We mitigate
690  *   the problem of an already unresponsive DNS server by allowing at most
691  *   1 outstanding query thread since we could potentially have a substantial
692  *   amount of clients hammering on the same DNS server attempting to get
693  *   the TXT record.
694  */
695 static void
696 get_dns_txt_domain(cb_t *argp)
697 {
698 	int		err;
699 #ifdef	DEBUG
700 	static uint64_t	msg_done = 0;
701 	char		*whoami = "get_dns_txt_domain";
702 #endif
703 	long		thr_flags = THR_DETACHED;
704 	struct stat	st;
705 
706 	/*
707 	 * We reset TXT variables first in case /etc/resolv.conf
708 	 * is missing or we've had unrecoverable resolver errors,
709 	 * we'll default to get_dns_domain(). If a previous DNS
710 	 * TXT RR was found, don't clear it until we're certain
711 	 * that contact can be made to the DNS server (see block
712 	 * comment atop resolv_txt_reset). If we're responding to
713 	 * a SIGHUP signal, force a reset of the cached copy.
714 	 */
715 	if (argp && argp->signal) {
716 		(void) rw_wrlock(&s_dns_data_lock);
717 		dns_txt_cached = 0;
718 		(void) rw_unlock(&s_dns_data_lock);
719 	}
720 	resolv_txt_reset();
721 
722 	errno = 0;
723 	if (stat(_PATH_RESCONF, &st) < 0 && errno == ENOENT) {
724 		/*
725 		 * If /etc/resolv.conf is not there, then we'll
726 		 * get the domain from domainname(1M). No real
727 		 * reason to query DNS or fire a thread since we
728 		 * have no nameserver addresses.
729 		 */
730 		goto txtclear;
731 	}
732 
733 	(void) rw_rdlock(&s_dns_impl_lock);
734 	if (s_dns_disabled) {
735 		/*
736 		 * If there were non-recoverable problems with DNS,
737 		 * we have stopped querying DNS entirely. See
738 		 * NO_RECOVERY clause below.
739 		 */
740 #ifdef	DEBUG
741 		syslog(LOG_ERR, "%s: DNS queries disabled", whoami);
742 #endif
743 		(void) rw_unlock(&s_dns_impl_lock);
744 		return;
745 	}
746 	(void) rw_unlock(&s_dns_impl_lock);
747 
748 	(void) resolv_init();
749 	switch (resolv_search()) {
750 	case NETDB_SUCCESS:
751 		/*
752 		 * If there _is_ a TXT record, we let
753 		 * our caller set the global state.
754 		 */
755 		resolv_decode();
756 		resolv_get_txt_data();
757 		return;
758 
759 	case TRY_AGAIN:
760 		if (argp == NULL || argp->fcn == NULL)
761 			/*
762 			 * If no valid argument was passed or
763 			 * callback defined, don't fire thread
764 			 */
765 			return;
766 
767 		(void) rw_wrlock(&s_dns_impl_lock);
768 		if (s_dns_qthr_created) {
769 			/*
770 			 * We may have lots of clients, so we don't
771 			 * want to bog down the DNS server with tons
772 			 * of requests... lest it becomes even more
773 			 * unresponsive, so limit 1 thread to query
774 			 * DNS at a time.
775 			 */
776 #ifdef	DEBUG
777 			syslog(LOG_ERR, "%s: query thread already active",
778 			    whoami);
779 #endif
780 			(void) rw_unlock(&s_dns_impl_lock);
781 				return;
782 		}
783 
784 		/*
785 		 * DNS did not respond ! Set timeout and kick off
786 		 * thread to try op again after s_dns_tout seconds.
787 		 * We've made sure that we don't have an already
788 		 * running thread above.
789 		 */
790 		s_dns_tout = NFSMAPID_DNS_TOUT_SECS;
791 		err = thr_create(NULL, 0, resolv_query_thread, (void *)argp,
792 		    thr_flags, &s_dns_qthread);
793 		if (!err) {
794 			s_dns_qthr_created = TRUE;
795 		}
796 #ifdef DEBUG
797 		else {
798 			msg_done++;
799 			if (!(msg_done % NFSMAPID_SLOG_RATE))
800 				syslog(LOG_ERR, EMSG_DNS_THREAD_ERROR);
801 		}
802 #endif
803 		(void) rw_unlock(&s_dns_impl_lock);
804 		return;
805 
806 	case NO_RECOVERY:
807 #ifdef	DEBUG
808 		syslog(LOG_ERR, EMSG_DNS_DISABLE, whoami);
809 #endif
810 		(void) rw_wrlock(&s_dns_impl_lock);
811 		s_dns_disabled = TRUE;
812 		(void) rw_unlock(&s_dns_impl_lock);
813 
814 		/*FALLTHROUGH*/
815 
816 	default:
817 		/*
818 		 * For any other errors... DNS is responding, but
819 		 * either it has no data, or some other problem is
820 		 * occuring. At any rate, the TXT domain should not
821 		 * be used, so we default to the DNS domain.
822 		 */
823 		break;
824 	}
825 
826 txtclear:
827 	(void) rw_wrlock(&s_dns_data_lock);
828 	dns_txt_cached = 0;
829 	(void) rw_unlock(&s_dns_data_lock);
830 	resolv_txt_reset();
831 }
832 
833 static int
834 get_mtime(const char *fname, timestruc_t *mtim)
835 {
836 	struct stat st;
837 	int err;
838 
839 	if ((err = stat(fname, &st)) != 0)
840 		return (err);
841 
842 	*mtim = st.st_mtim;
843 	return (0);
844 }
845 
846 
847 /*
848  * trim_wspace is a destructive interface; it is up to
849  * the caller to save off an original copy if needed.
850  */
851 static char *
852 trim_wspace(char *dp)
853 {
854 	char	*r;
855 	char	*ndp;
856 
857 	/*
858 	 * Any empty domain is not valid
859 	 */
860 	if (dp == NULL)
861 		return (NULL);
862 
863 	/*
864 	 * Skip leading blanks
865 	 */
866 	for (ndp = dp; *ndp != '\0'; ndp++) {
867 		if (!isspace(*ndp))
868 			break;
869 	}
870 
871 	/*
872 	 * If we reached the end of the string w/o
873 	 * finding a non-blank char, return error
874 	 */
875 	if (*ndp == '\0')
876 		return (NULL);
877 
878 	/*
879 	 * Find next blank in string
880 	 */
881 	for (r = ndp; *r != '\0'; r++) {
882 		if (isspace(*r))
883 			break;
884 	}
885 
886 	/*
887 	 * No more blanks found, we are done
888 	 */
889 	if (*r == '\0')
890 		return (ndp);
891 
892 	/*
893 	 * Terminate string at blank
894 	 */
895 	*r++ = '\0';
896 
897 	/*
898 	 * Skip any trailing spaces
899 	 */
900 	while (*r != '\0') {
901 		/*
902 		 * If a non-blank is found, it is an
903 		 * illegal domain (embedded blanks).
904 		 */
905 		if (!isspace(*r))
906 			return (NULL);
907 		r++;
908 	}
909 	return (ndp);
910 }
911 
912 static void
913 get_nfs_domain(void)
914 {
915 	char		*ndomain;
916 	timestruc_t	 ntime;
917 
918 	/*
919 	 * If we can't get stats for the config file, then
920 	 * zap the NFS domain info.  If mtime hasn't changed,
921 	 * then there's no work to do, so just return.
922 	 */
923 	if (get_mtime(NFSADMIN, &ntime) != 0) {
924 		ZAP_DOMAIN(nfs);
925 		return;
926 	}
927 
928 	if (TIMESTRUC_EQ(ntime, nfs_mtime))
929 		return;
930 
931 	/*
932 	 * Get NFSMAPID_DOMAIN value from /etc/default/nfs for now.
933 	 * Note: defread() returns a ptr to TSD.
934 	 */
935 	if (defopen(NFSADMIN) == 0) {
936 		char	*dp = NULL;
937 #ifdef	DEBUG
938 		char	*whoami = "get_nfs_domain";
939 		char	 orig[NS_MAXCDNAME] = {0};
940 #endif
941 		ndomain = (char *)defread("NFSMAPID_DOMAIN=");
942 		(void) defopen(NULL);
943 #ifdef	DEBUG
944 		if (ndomain)
945 			(void) strncpy(orig, ndomain, NS_MAXCDNAME);
946 #endif
947 		/*
948 		 * NFSMAPID_DOMAIN was set, so it's time for validation. If
949 		 * it's okay, then update NFS domain and return. If not,
950 		 * bail (syslog in DEBUG). We make nfsmapid more a bit
951 		 * more forgiving of trailing and leading white space.
952 		 */
953 		if ((dp = trim_wspace(ndomain)) != NULL) {
954 			if (mapid_stdchk_domain(dp) > 0) {
955 				nfs_domain_len = strlen(dp);
956 				(void) strncpy(nfs_domain, dp, NS_MAXCDNAME);
957 				nfs_domain[NS_MAXCDNAME] = '\0';
958 				nfs_mtime = ntime;
959 				return;
960 			}
961 		}
962 #ifdef	DEBUG
963 		if (orig[0] != '\0') {
964 			syslog(LOG_ERR, gettext("%s: Invalid domain name \"%s\""
965 				" found in configuration file."), whoami, orig);
966 		}
967 #endif
968 	}
969 
970 	/*
971 	 * So the NFS config file changed but it couldn't be opened or
972 	 * it didn't specify NFSMAPID_DOMAIN or it specified an invalid
973 	 * NFSMAPID_DOMAIN.  Time to zap current NFS domain info.
974 	 */
975 	ZAP_DOMAIN(nfs);
976 }
977 
978 static void
979 get_dns_domain(void)
980 {
981 	timestruc_t	 ntime = {0};
982 
983 	/*
984 	 * If we can't get stats for the config file, then
985 	 * zap the DNS domain info.  If mtime hasn't changed,
986 	 * then there's no work to do, so just return.
987 	 */
988 	errno = 0;
989 	if (get_mtime(_PATH_RESCONF, &ntime) != 0) {
990 		switch (errno) {
991 			case ENOENT:
992 				/*
993 				 * The resolver defaults to obtaining the
994 				 * domain off of the NIS domainname(1M) if
995 				 * /etc/resolv.conf does not exist, so we
996 				 * move forward.
997 				 */
998 				break;
999 
1000 			default:
1001 				ZAP_DOMAIN(dns);
1002 				return;
1003 		}
1004 	} else if (TIMESTRUC_EQ(ntime, dns_mtime))
1005 		return;
1006 
1007 	/*
1008 	 * Re-initialize resolver to zap DNS domain from previous
1009 	 * resolv_init() calls.
1010 	 */
1011 	(void) resolv_init();
1012 
1013 	/*
1014 	 * Update cached DNS domain.  No need for validation since
1015 	 * domain comes from resolver.  If resolver doesn't return the
1016 	 * domain, then zap the DNS domain.  This shouldn't ever happen,
1017 	 * and if it does, the machine has bigger problems (so no need
1018 	 * to generate a message that says DNS appears to be broken).
1019 	 */
1020 	(void) rw_rdlock(&s_dns_data_lock);
1021 	if (sysdns_domain[0] != '\0') {
1022 		(void) strncpy(dns_domain, sysdns_domain, NS_MAXCDNAME);
1023 		dns_domain_len = strlen(sysdns_domain);
1024 		(void) rw_unlock(&s_dns_data_lock);
1025 		dns_mtime = ntime;
1026 		return;
1027 	}
1028 	(void) rw_unlock(&s_dns_data_lock);
1029 
1030 	ZAP_DOMAIN(dns);
1031 }
1032 
1033 /*
1034  * PSARC 2005/487 Contracted Sun Private Interface
1035  * mapid_stdchk_domain()
1036  * Changes must be reviewed by Solaris File Sharing
1037  * Changes must be communicated to contract-2005-487-01@sun.com
1038  *
1039  * Based on the recommendations from RFC1033 and RFC1035, check
1040  * if a given domain name string is valid. Return values are:
1041  *
1042  *       1 = valid domain name
1043  *       0 = invalid domain name (or invalid embedded character)
1044  *      -1 = domain length > NS_MAXCDNAME
1045  */
1046 int
1047 mapid_stdchk_domain(const char *ds)
1048 {
1049 	int	i;
1050 	size_t	len;
1051 
1052 	if (ds[0] == '\0')
1053 		return (0);
1054 	else
1055 		len = strlen(ds) - 1;
1056 
1057 	/*
1058 	 * 1st char _must_ be alphabetic char _AND_ last char _must_
1059 	 * be alphanumeric. We check for other valid chars below.
1060 	 */
1061 	if (!isalpha(ds[0]) || !isalpha(ds[len]) && !isdigit(ds[len]))
1062 		return (0);
1063 
1064 	for (i = 0; *ds && i <= NS_MAXCDNAME; i++, ds++) {
1065 		if (!isalpha(*ds) && !isdigit(*ds) &&
1066 		    (*ds != '.') && (*ds != '-') && (*ds != '_'))
1067 			return (0);
1068 	}
1069 	return (i == (NS_MAXCDNAME + 1) ? -1 : 1);
1070 }
1071 
1072 /*
1073  * PSARC 2005/487 Consolidation Private
1074  * mapid_reeval_domain()
1075  * Changes must be reviewed by Solaris File Sharing
1076  */
1077 void
1078 mapid_reeval_domain(cb_t *arg)
1079 {
1080 	char	*domain = NULL;
1081 
1082 	get_nfs_domain();
1083 	if (nfs_domain_len != 0) {
1084 		domain = nfs_domain;
1085 		goto dsync;
1086 	}
1087 
1088 	get_dns_txt_domain(arg);
1089 	if (dns_txt_domain_len != 0)
1090 		domain = dns_txt_domain;
1091 	else {
1092 		/*
1093 		 * We're either here because:
1094 		 *
1095 		 *  . NFSMAPID_DOMAIN was not set in /etc/default/nfs
1096 		 *  . No suitable DNS TXT resource record exists
1097 		 *  . DNS server is not responding to requests
1098 		 *
1099 		 * in either case, we want to default to using the
1100 		 * system configured DNS domain. If this fails, then
1101 		 * dns_domain will be empty and dns_domain_len will
1102 		 * be 0.
1103 		 */
1104 		get_dns_domain();
1105 		domain = dns_domain;
1106 	}
1107 
1108 dsync:
1109 	domain_sync(arg, domain);
1110 }
1111 
1112 /*
1113  * PSARC 2005/487 Consolidation Private
1114  * mapid_get_domain()
1115  * Changes must be reviewed by Solaris File Sharing
1116  *
1117  * The use of TSD in mapid_get_domain() diverges slightly from the typical
1118  * TSD use, since here, the benefit of doing TSD is mostly to allocate
1119  * a per-thread buffer that will be utilized by other up-calls to the
1120  * daemon.
1121  *
1122  * In doors, the thread used for the upcall never really exits, hence
1123  * the typical destructor function defined via thr_keycreate() will
1124  * never be called. Thus, we only use TSD to allocate the per-thread
1125  * buffer and fill it up w/the configured 'mapid_domain' on each call.
1126  * This still alleviates the problem of having the caller free any
1127  * malloc'd space.
1128  */
1129 char *
1130 mapid_get_domain(void)
1131 {
1132 	void	*tsd = NULL;
1133 
1134 	(void) thr_getspecific(s_thr_key, &tsd);
1135 	if (tsd == NULL) {
1136 		tsd = malloc(NS_MAXCDNAME+1);
1137 		if (tsd != NULL) {
1138 			(void) rw_rdlock(&mapid_domain_lock);
1139 			(void) strncpy((char *)tsd, mapid_domain, NS_MAXCDNAME);
1140 			(void) rw_unlock(&mapid_domain_lock);
1141 			(void) thr_setspecific(s_thr_key, tsd);
1142 		}
1143 	} else {
1144 		(void) rw_rdlock(&mapid_domain_lock);
1145 		(void) strncpy((char *)tsd, mapid_domain, NS_MAXCDNAME);
1146 		(void) rw_unlock(&mapid_domain_lock);
1147 	}
1148 	return ((char *)tsd);
1149 }
1150 
1151 /*
1152  * PSARC 2005/487 Contracted Sun Private Interface
1153  * mapid_derive_domain()
1154  * Changes must be reviewed by Solaris File Sharing
1155  * Changes must be communicated to contract-2005-487-01@sun.com
1156  *
1157  * This interface is called solely via sysidnfs4 iff no
1158  * NFSMAPID_DOMAIN was found. So, there is no ill effect
1159  * of having the reeval function call get_nfs_domain().
1160  */
1161 char *
1162 mapid_derive_domain(void)
1163 {
1164 	cb_t	cb = {0};
1165 
1166 	_lib_init();
1167 	mapid_reeval_domain(&cb);
1168 	return (mapid_get_domain());
1169 }
1170 
1171 void
1172 _lib_init(void)
1173 {
1174 	(void) resolv_init();
1175 	(void) rwlock_init(&mapid_domain_lock, USYNC_THREAD, NULL);
1176 	(void) thr_keycreate(&s_thr_key, NULL);
1177 	lib_init_done++;
1178 }
1179