1 /*
2 NICTA Public Software Licence
3 Version 1.0
4
5 Copyright © 2004 National ICT Australia Ltd
6
7 All rights reserved.
8
9 By this licence, National ICT Australia Ltd (NICTA) grants permission,
10 free of charge, to any person who obtains a copy of this software
11 and any associated documentation files ("the Software") to use and
12 deal with the Software in source code and binary forms without
13 restriction, with or without modification, and to permit persons
14 to whom the Software is furnished to do so, provided that the
15 following conditions are met:
16
17 - Redistributions of source code must retain the above copyright
18 notice, this list of conditions and the following disclaimers.
19 - Redistributions in binary form must reproduce the above copyright
20 notice, this list of conditions and the following disclaimers in
21 the documentation and/or other materials provided with the
22 distribution.
23 - The name of NICTA may not be used to endorse or promote products
24 derived from this Software without specific prior written permission.
25
26 EXCEPT AS EXPRESSLY STATED IN THIS LICENCE AND TO THE FULL EXTENT
27 PERMITTED BY APPLICABLE LAW, THE SOFTWARE IS PROVIDED "AS-IS" AND
28 NICTA MAKES NO REPRESENTATIONS, WARRANTIES OR CONDITIONS OF ANY
29 KIND, EXPRESS OR IMPLIED, INCLUDING, WITHOUT LIMITATION, ANY
30 REPRESENTATIONS, WARRANTIES OR CONDITIONS REGARDING THE CONTENTS
31 OR ACCURACY OF THE SOFTWARE, OR OF TITLE, MERCHANTABILITY, FITNESS
32 FOR A PARTICULAR PURPOSE, NONINFRINGEMENT, THE ABSENCE OF LATENT
33 OR OTHER DEFECTS, OR THE PRESENCE OR ABSENCE OF ERRORS, WHETHER OR
34 NOT DISCOVERABLE.
35
36 TO THE FULL EXTENT PERMITTED BY APPLICABLE LAW, IN NO EVENT WILL
37 NICTA BE LIABLE ON ANY LEGAL THEORY (INCLUDING, WITHOUT LIMITATION,
38 NEGLIGENCE) FOR ANY LOSS OR DAMAGE WHATSOEVER, INCLUDING (WITHOUT
39 LIMITATION) LOSS OF PRODUCTION OR OPERATION TIME, LOSS, DAMAGE OR
40 CORRUPTION OF DATA OR RECORDS; OR LOSS OF ANTICIPATED SAVINGS,
41 OPPORTUNITY, REVENUE, PROFIT OR GOODWILL, OR OTHER ECONOMIC LOSS;
42 OR ANY SPECIAL, INCIDENTAL, INDIRECT, CONSEQUENTIAL, PUNITIVE OR
43 EXEMPLARY DAMAGES ARISING OUT OF OR IN CONNECTION WITH THIS LICENCE,
44 THE SOFTWARE OR THE USE OF THE SOFTWARE, EVEN IF NICTA HAS BEEN
45 ADVISED OF THE POSSIBILITY OF SUCH DAMAGES.
46
47 If applicable legislation implies warranties or conditions, or
48 imposes obligations or liability on NICTA in respect of the Software
49 that cannot be wholly or partly excluded, restricted or modified,
50 NICTA's liability is limited, to the full extent permitted by the
51 applicable legislation, at its option, to:
52
53 a. in the case of goods, any one or more of the following:
54 i. the replacement of the goods or the supply of equivalent goods;
55 ii. the repair of the goods;
56 iii. the payment of the cost of replacing the goods or of acquiring
57 equivalent goods;
58 iv. the payment of the cost of having the goods repaired; or
59 b. in the case of services:
60 i. the supplying of the services again; or
61 ii. the payment of the cost of having the services supplied
62 again.
63 */
64
65 /*
66 NSSwitch Implementation of mDNS interface.
67
68 Andrew White (Andrew.White@nicta.com.au)
69 May 2004
70 */
71
72 #include <stdlib.h>
73 #include <stdio.h>
74 #include <string.h>
75 #include <errno.h>
76 #include <syslog.h>
77 #include <pthread.h>
78 #include <ctype.h>
79
80 #include <sys/types.h>
81 #include <sys/time.h>
82 #include <sys/socket.h>
83
84 #include <netinet/in.h>
85
86 #include <arpa/inet.h>
87 #define BIND_8_COMPAT 1
88 #include <arpa/nameser.h>
89
90 #include <dns_sd.h>
91
92
93 //----------
94 // Public functions
95
96 /*
97 Count the number of dots in a name string.
98 */
99 int
100 count_dots (const char * name);
101
102
103 /*
104 Test whether a domain name is local.
105
106 Returns
107 1 if name ends with ".local" or ".local."
108 0 otherwise
109 */
110 int
111 islocal (const char * name);
112
113
114 /*
115 Format an address structure as a string appropriate for DNS reverse (PTR)
116 lookup, based on address type.
117
118 Parameters
119 prefixlen
120 Prefix length, in bits. When formatting, this will be rounded up
121 to the nearest appropriate size. If -1, assume maximum.
122 buf
123 Output buffer. Must be long enough to hold largest possible
124 output.
125 Returns
126 Pointer to (first character of) output buffer,
127 or NULL on error.
128 */
129 char *
130 format_reverse_addr (int af, const void * addr, int prefixlen, char * buf);
131
132
133 /*
134 Format an address structure as a string appropriate for DNS reverse (PTR)
135 lookup for AF_INET. Output is in .in-addr.arpa domain.
136
137 Parameters
138 prefixlen
139 Prefix length, in bits. When formatting, this will be rounded up
140 to the nearest byte (8). If -1, assume 32.
141 buf
142 Output buffer. Must be long enough to hold largest possible
143 output. For AF_INET, this is 29 characters (including null).
144 Returns
145 Pointer to (first character of) output buffer,
146 or NULL on error.
147 */
148 char *
149 format_reverse_addr_in (
150 const struct in_addr * addr,
151 int prefixlen,
152 char * buf
153 );
154 #define DNS_PTR_AF_INET_SIZE 29
155
156 /*
157 Format an address structure as a string appropriate for DNS reverse (PTR)
158 lookup for AF_INET6. Output is in .ip6.arpa domain.
159
160 Parameters
161 prefixlen
162 Prefix length, in bits. When formatting, this will be rounded up
163 to the nearest nibble (4). If -1, assume 128.
164 buf
165 Output buffer. Must be long enough to hold largest possible
166 output. For AF_INET6, this is 72 characters (including null).
167 Returns
168 Pointer to (first character of) output buffer,
169 or NULL on error.
170 */
171 char *
172 format_reverse_addr_in6 (
173 const struct in6_addr * addr,
174 int prefixlen,
175 char * buf
176 );
177 #define DNS_PTR_AF_INET6_SIZE 72
178
179
180 /*
181 Compare whether the given dns name has the given domain suffix.
182 A single leading '.' on the name or leading or trailing '.' on the
183 domain is ignored for the purposes of the comparison.
184 Multiple leading or trailing '.'s are an error. Other DNS syntax
185 errors are not checked for. The comparison is case insensitive.
186
187 Returns
188 1 on success (match)
189 0 on failure (no match)
190 < 0 on error
191 */
192 int
193 cmp_dns_suffix (const char * name, const char * domain);
194 enum
195 {
196 CMP_DNS_SUFFIX_SUCCESS = 1,
197 CMP_DNS_SUFFIX_FAILURE = 0,
198 CMP_DNS_SUFFIX_BAD_NAME = 1,
199 CMP_DNS_SUFFIX_BAD_DOMAIN = -2
200 };
201
202 typedef int ns_type_t;
203 typedef int ns_class_t;
204
205 /*
206 Convert a DNS resource record (RR) code to an address family (AF) code.
207
208 Parameters
209 rrtype
210 resource record type (from nameser.h)
211
212 Returns
213 Appropriate AF code (from socket.h), or AF_UNSPEC if an appropriate
214 mapping couldn't be determined
215 */
216 int
217 rr_to_af (ns_type_t rrtype);
218
219
220 /*
221 Convert an address family (AF) code to a DNS resource record (RR) code.
222
223 Parameters
224 int
225 address family code (from socket.h)
226 Returns
227 Appropriate RR code (from nameser.h), or ns_t_invalid if an appropriate
228 mapping couldn't be determined
229 */
230 ns_type_t
231 af_to_rr (int af);
232
233
234 /*
235 Convert a string to an address family (case insensitive).
236
237 Returns
238 Matching AF code, or AF_UNSPEC if no match found.
239 */
240 int
241 str_to_af (const char * str);
242
243
244 /*
245 Convert a string to an ns_class_t (case insensitive).
246
247 Returns
248 Matching ns_class_t, or ns_c_invalid if no match found.
249 */
250 ns_class_t
251 str_to_ns_class (const char * str);
252
253
254 /*
255 Convert a string to an ns_type_t (case insensitive).
256
257 Returns
258 Matching ns_type_t, or ns_t_invalid if no match found.
259 */
260 ns_type_t
261 str_to_ns_type (const char * str);
262
263
264 /*
265 Convert an address family code to a string.
266
267 Returns
268 String representation of AF,
269 or NULL if address family unrecognised or invalid.
270 */
271 const char *
272 af_to_str (int in);
273
274
275 /*
276 Convert an ns_class_t code to a string.
277
278 Returns
279 String representation of ns_class_t,
280 or NULL if ns_class_t unrecognised or invalid.
281 */
282 const char *
283 ns_class_to_str (ns_class_t in);
284
285
286 /*
287 Convert an ns_type_t code to a string.
288
289 Returns
290 String representation of ns_type_t,
291 or NULL if ns_type_t unrecognised or invalid.
292 */
293 const char *
294 ns_type_to_str (ns_type_t in);
295
296
297 /*
298 Convert DNS rdata in label format (RFC1034, RFC1035) to a name.
299
300 On error, partial data is written to name (as much as was successfully
301 processed) and an error code is returned. Errors include a name too
302 long for the buffer and a pointer in the label (which cannot be
303 resolved).
304
305 Parameters
306 rdata
307 Rdata formatted as series of labels.
308 rdlen
309 Length of rdata buffer.
310 name
311 Buffer to store fully qualified result in.
312 By RFC1034 section 3.1, a 255 character buffer (256 characters
313 including null) is long enough for any legal name.
314 name_len
315 Number of characters available in name buffer, not including
316 trailing null.
317
318 Returns
319 Length of name buffer (not including trailing null).
320 < 0 on error.
321 A return of 0 implies the empty domain.
322 */
323 int
324 dns_rdata_to_name (const char * rdata, int rdlen, char * name, int name_len);
325 enum
326 {
327 DNS_RDATA_TO_NAME_BAD_FORMAT = -1,
328 // Format is broken. Usually because we ran out of data
329 // (according to rdata) before the labels said we should.
330 DNS_RDATA_TO_NAME_TOO_LONG = -2,
331 // The converted rdata is longer than the name buffer.
332 DNS_RDATA_TO_NAME_PTR = -3,
333 // The rdata contains a pointer.
334 };
335
336 #define DNS_LABEL_MAXLEN 63
337 // Maximum length of a single DNS label
338 #define DNS_NAME_MAXLEN 256
339 // Maximum length of a DNS name
340
341 //----------
342 // Public types
343
344 typedef int errcode_t;
345 // Used for 0 = success, non-zero = error code functions
346
347
348 //----------
349 // Public functions
350
351 /*
352 Test whether a domain name is in a domain covered by nss_mdns.
353 The name is assumed to be fully qualified (trailing dot optional);
354 unqualified names will be processed but may return unusual results
355 if the unqualified prefix happens to match a domain suffix.
356
357 Returns
358 1 success
359 0 failure
360 -1 error, check errno
361 */
362 int
363 config_is_mdns_suffix (const char * name);
364
365
366 /*
367 Loads all relevant data from configuration file. Other code should
368 rarely need to call this function, since all other public configuration
369 functions do so implicitly. Once loaded, configuration info doesn't
370 change.
371
372 Returns
373 0 configuration ready
374 non-zero configuration error code
375 */
376 errcode_t
377 init_config ();
378
379 #define ENTNAME hostent
380 #define DATABASE "hosts"
381
382 #include <nss.h>
383 // For nss_status
384 #include <netdb.h>
385 // For hostent
386 #include <sys/types.h>
387 // For size_t
388
389 typedef enum nss_status nss_status;
390 typedef struct hostent hostent;
391
392 /*
393 gethostbyname implementation
394
395 name:
396 name to look up
397 result_buf:
398 resulting entry
399 buf:
400 auxillary buffer
401 buflen:
402 length of auxillary buffer
403 errnop:
404 pointer to errno
405 h_errnop:
406 pointer to h_errno
407 */
408 nss_status
409 _nss_mdns_gethostbyname_r (
410 const char *name,
411 hostent * result_buf,
412 char *buf,
413 size_t buflen,
414 int *errnop,
415 int *h_errnop
416 );
417
418
419 /*
420 gethostbyname2 implementation
421
422 name:
423 name to look up
424 af:
425 address family
426 result_buf:
427 resulting entry
428 buf:
429 auxillary buffer
430 buflen:
431 length of auxillary buffer
432 errnop:
433 pointer to errno
434 h_errnop:
435 pointer to h_errno
436 */
437 nss_status
438 _nss_mdns_gethostbyname2_r (
439 const char *name,
440 int af,
441 hostent * result_buf,
442 char *buf,
443 size_t buflen,
444 int *errnop,
445 int *h_errnop
446 );
447
448
449 /*
450 gethostbyaddr implementation
451
452 addr:
453 address structure to look up
454 len:
455 length of address structure
456 af:
457 address family
458 result_buf:
459 resulting entry
460 buf:
461 auxillary buffer
462 buflen:
463 length of auxillary buffer
464 errnop:
465 pointer to errno
466 h_errnop:
467 pointer to h_errno
468 */
469 nss_status
470 _nss_mdns_gethostbyaddr_r (
471 const void *addr,
472 socklen_t len,
473 int af,
474 hostent * result_buf,
475 char *buf,
476 size_t buflen,
477 int *errnop,
478 int *h_errnop
479 );
480
481
482 //----------
483 // Types and Constants
484
485 const int MDNS_VERBOSE = 0;
486 // This enables verbose syslog messages
487 // If zero, only "imporant" messages will appear in syslog
488
489 #define k_hostname_maxlen 256
490 // As per RFC1034 and RFC1035
491 #define k_aliases_max 15
492 #define k_addrs_max 15
493
494 typedef struct buf_header
495 {
496 char hostname [k_hostname_maxlen + 1];
497 char * aliases [k_aliases_max + 1];
498 char * addrs [k_addrs_max + 1];
499 } buf_header_t;
500
501 typedef struct result_map
502 {
503 int done;
504 nss_status status;
505 hostent * hostent;
506 buf_header_t * header;
507 int aliases_count;
508 int addrs_count;
509 char * buffer;
510 int addr_idx;
511 // Index for addresses - grow from low end
512 // Index points to first empty space
513 int alias_idx;
514 // Index for aliases - grow from high end
515 // Index points to lowest entry
516 int r_errno;
517 int r_h_errno;
518 } result_map_t;
519
520 static const struct timeval
521 k_select_time = { 0, 500000 };
522 // 0 seconds, 500 milliseconds
523
524 //----------
525 // Local prototypes
526
527 static nss_status
528 mdns_gethostbyname2 (
529 const char *name,
530 int af,
531 hostent * result_buf,
532 char *buf,
533 size_t buflen,
534 int *errnop,
535 int *h_errnop
536 );
537
538
539 /*
540 Lookup name using mDNS server
541 */
542 static nss_status
543 mdns_lookup_name (
544 const char * fullname,
545 int af,
546 result_map_t * result
547 );
548
549 /*
550 Lookup address using mDNS server
551 */
552 static nss_status
553 mdns_lookup_addr (
554 const void * addr,
555 socklen_t len,
556 int af,
557 const char * addr_str,
558 result_map_t * result
559 );
560
561
562 /*
563 Handle incoming MDNS events
564 */
565 static nss_status
566 handle_events (DNSServiceRef sdref, result_map_t * result, const char * str);
567
568
569 // Callback for mdns_lookup operations
570 //DNSServiceQueryRecordReply mdns_lookup_callback;
571 typedef void
572 mdns_lookup_callback_t
573 (
574 DNSServiceRef sdref,
575 DNSServiceFlags flags,
576 uint32_t interface_index,
577 DNSServiceErrorType error_code,
578 const char *fullname,
579 uint16_t rrtype,
580 uint16_t rrclass,
581 uint16_t rdlen,
582 const void *rdata,
583 uint32_t ttl,
584 void *context
585 );
586
587 mdns_lookup_callback_t mdns_lookup_callback;
588
589
590 static int
591 init_result (
592 result_map_t * result,
593 hostent * result_buf,
594 char * buf,
595 size_t buflen
596 );
597
598 static int
599 callback_body_ptr (
600 const char * fullname,
601 result_map_t * result,
602 int rdlen,
603 const void * rdata
604 );
605
606 static void *
607 add_address_to_buffer (result_map_t * result, const void * data, int len);
608 static char *
609 add_alias_to_buffer (result_map_t * result, const char * data, int len);
610 static char *
611 add_hostname_len (result_map_t * result, const char * fullname, int len);
612 static char *
613 add_hostname_or_alias (result_map_t * result, const char * data, int len);
614
615 static void *
616 contains_address (result_map_t * result, const void * data, int len);
617 static char *
618 contains_alias (result_map_t * result, const char * data);
619
620
621 static const char *
622 is_applicable_name (
623 result_map_t * result,
624 const char * name,
625 char * lookup_name
626 );
627
628 static const char *
629 is_applicable_addr (
630 result_map_t * result,
631 const void * addr,
632 int af,
633 char * addr_str
634 );
635
636
637 // Error code functions
638
639 static nss_status
640 set_err (result_map_t * result, nss_status status, int err, int herr);
641
642 static nss_status set_err_notfound (result_map_t * result);
643 static nss_status set_err_bad_hostname (result_map_t * result);
644 static nss_status set_err_buf_too_small (result_map_t * result);
645 static nss_status set_err_internal_resource_full (result_map_t * result);
646 static nss_status set_err_system (result_map_t * result);
647 static nss_status set_err_mdns_failed (result_map_t * result);
648 static nss_status set_err_success (result_map_t * result);
649
650
651 //----------
652 // Global variables
653
654
655 //----------
656 // NSS functions
657
658 nss_status
_nss_mdns_gethostbyname_r(const char * name,hostent * result_buf,char * buf,size_t buflen,int * errnop,int * h_errnop)659 _nss_mdns_gethostbyname_r (
660 const char *name,
661 hostent * result_buf,
662 char *buf,
663 size_t buflen,
664 int *errnop,
665 int *h_errnop
666 )
667 {
668 if (MDNS_VERBOSE)
669 syslog (LOG_DEBUG,
670 "mdns: Called nss_mdns_gethostbyname with %s",
671 name
672 );
673
674 return
675 mdns_gethostbyname2 (
676 name, AF_INET, result_buf, buf, buflen, errnop, h_errnop
677 );
678 }
679
680
681 nss_status
_nss_mdns_gethostbyname2_r(const char * name,int af,hostent * result_buf,char * buf,size_t buflen,int * errnop,int * h_errnop)682 _nss_mdns_gethostbyname2_r (
683 const char *name,
684 int af,
685 hostent * result_buf,
686 char *buf,
687 size_t buflen,
688 int *errnop,
689 int *h_errnop
690 )
691 {
692 if (MDNS_VERBOSE)
693 syslog (LOG_DEBUG,
694 "mdns: Called nss_mdns_gethostbyname2 with %s",
695 name
696 );
697
698 return
699 mdns_gethostbyname2 (
700 name, af, result_buf, buf, buflen, errnop, h_errnop
701 );
702 }
703
704
705 nss_status
_nss_mdns_gethostbyaddr_r(const void * addr,socklen_t len,int af,hostent * result_buf,char * buf,size_t buflen,int * errnop,int * h_errnop)706 _nss_mdns_gethostbyaddr_r (
707 const void *addr,
708 socklen_t len,
709 int af,
710 hostent * result_buf,
711 char *buf,
712 size_t buflen,
713 int *errnop,
714 int *h_errnop
715 )
716 {
717 char addr_str [NI_MAXHOST + 1];
718 result_map_t result;
719 int err_status;
720
721 if (inet_ntop (af, addr, addr_str, NI_MAXHOST) == NULL)
722 {
723 const char * family = af_to_str (af);
724 if (family == NULL)
725 {
726 family = "Unknown";
727 }
728
729 syslog (LOG_WARNING,
730 "mdns: Couldn't covert address, family %d (%s) in nss_mdns_gethostbyaddr: %s",
731 af,
732 family,
733 strerror (errno)
734 );
735
736 // This address family never applicable to us, so return NOT_FOUND
737
738 *errnop = ENOENT;
739 *h_errnop = HOST_NOT_FOUND;
740 return NSS_STATUS_NOTFOUND;
741 }
742 if (MDNS_VERBOSE)
743 {
744 syslog (LOG_DEBUG,
745 "mdns: Called nss_mdns_gethostbyaddr with %s",
746 addr_str
747 );
748 }
749
750 // Initialise result
751 err_status = init_result (&result, result_buf, buf, buflen);
752 if (err_status)
753 {
754 *errnop = err_status;
755 *h_errnop = NETDB_INTERNAL;
756 return NSS_STATUS_TRYAGAIN;
757 }
758
759 if (is_applicable_addr (&result, addr, af, addr_str))
760 {
761 nss_status rv;
762
763 rv = mdns_lookup_addr (addr, len, af, addr_str, &result);
764 if (rv == NSS_STATUS_SUCCESS)
765 {
766 return rv;
767 }
768 }
769
770 // Return current error status (defaults to NOT_FOUND)
771
772 *errnop = result.r_errno;
773 *h_errnop = result.r_h_errno;
774 return result.status;
775 }
776
777
778 //----------
779 // Local functions
780
781 nss_status
mdns_gethostbyname2(const char * name,int af,hostent * result_buf,char * buf,size_t buflen,int * errnop,int * h_errnop)782 mdns_gethostbyname2 (
783 const char *name,
784 int af,
785 hostent * result_buf,
786 char *buf,
787 size_t buflen,
788 int *errnop,
789 int *h_errnop
790 )
791 {
792 char lookup_name [k_hostname_maxlen + 1];
793 result_map_t result;
794 int err_status;
795
796 // Initialise result
797 err_status = init_result (&result, result_buf, buf, buflen);
798 if (err_status)
799 {
800 *errnop = err_status;
801 *h_errnop = NETDB_INTERNAL;
802 return NSS_STATUS_TRYAGAIN;
803 }
804
805 if (is_applicable_name (&result, name, lookup_name))
806 {
807 // Try using mdns
808 nss_status rv;
809
810 if (MDNS_VERBOSE)
811 syslog (LOG_DEBUG,
812 "mdns: Local name: %s",
813 name
814 );
815
816 rv = mdns_lookup_name (name, af, &result);
817 if (rv == NSS_STATUS_SUCCESS)
818 {
819 return rv;
820 }
821 }
822
823 // Return current error status (defaults to NOT_FOUND)
824
825 *errnop = result.r_errno;
826 *h_errnop = result.r_h_errno;
827 return result.status;
828 }
829
830
831 /*
832 Lookup a fully qualified hostname using the default record type
833 for the specified address family.
834
835 Parameters
836 fullname
837 Fully qualified hostname. If not fully qualified the code will
838 still 'work', but the lookup is unlikely to succeed.
839 af
840 Either AF_INET or AF_INET6. Other families are not supported.
841 result
842 Initialised 'result' data structure.
843 */
844 static nss_status
mdns_lookup_name(const char * fullname,int af,result_map_t * result)845 mdns_lookup_name (
846 const char * fullname,
847 int af,
848 result_map_t * result
849 )
850 {
851 // Lookup using mDNS.
852 DNSServiceErrorType errcode;
853 DNSServiceRef sdref;
854 ns_type_t rrtype;
855 nss_status status;
856
857 if (MDNS_VERBOSE)
858 syslog (LOG_DEBUG,
859 "mdns: Attempting lookup of %s",
860 fullname
861 );
862
863 switch (af)
864 {
865 case AF_INET:
866 rrtype = kDNSServiceType_A;
867 result->hostent->h_length = 4;
868 // Length of an A record
869 break;
870
871 case AF_INET6:
872 rrtype = kDNSServiceType_AAAA;
873 result->hostent->h_length = 16;
874 // Length of an AAAA record
875 break;
876
877 default:
878 syslog (LOG_WARNING,
879 "mdns: Unsupported address family %d",
880 af
881 );
882 return set_err_bad_hostname (result);
883 }
884 result->hostent->h_addrtype = af;
885
886 errcode =
887 DNSServiceQueryRecord (
888 &sdref,
889 kDNSServiceFlagsForceMulticast, // force multicast query
890 kDNSServiceInterfaceIndexAny, // all interfaces
891 fullname, // full name to query for
892 rrtype, // resource record type
893 kDNSServiceClass_IN, // internet class records
894 mdns_lookup_callback, // callback
895 result // Context - result buffer
896 );
897
898 if (errcode)
899 {
900 syslog (LOG_WARNING,
901 "mdns: Failed to initialise lookup, error %d",
902 errcode
903 );
904 return set_err_mdns_failed (result);
905 }
906
907 status = handle_events (sdref, result, fullname);
908 DNSServiceRefDeallocate (sdref);
909 return status;
910 }
911
912
913 /*
914 Reverse (PTR) lookup for the specified address.
915
916 Parameters
917 addr
918 Either a struct in_addr or a struct in6_addr
919 addr_len
920 size of the address
921 af
922 Either AF_INET or AF_INET6. Other families are not supported.
923 Must match addr
924 addr_str
925 Address in format suitable for PTR lookup.
926 AF_INET: a.b.c.d -> d.c.b.a.in-addr.arpa
927 AF_INET6: reverse nibble format, x.x.x...x.ip6.arpa
928 result
929 Initialised 'result' data structure.
930 */
931 static nss_status
mdns_lookup_addr(const void * addr,socklen_t addr_len,int af,const char * addr_str,result_map_t * result)932 mdns_lookup_addr (
933 const void * addr,
934 socklen_t addr_len,
935 int af,
936 const char * addr_str,
937 result_map_t * result
938 )
939 {
940 DNSServiceErrorType errcode;
941 DNSServiceRef sdref;
942 nss_status status;
943
944 if (MDNS_VERBOSE)
945 syslog (LOG_DEBUG,
946 "mdns: Attempting lookup of %s",
947 addr_str
948 );
949
950 result->hostent->h_addrtype = af;
951 result->hostent->h_length = addr_len;
952
953 // Query address becomes "address" in result.
954 if (! add_address_to_buffer (result, addr, addr_len))
955 {
956 return result->status;
957 }
958
959 result->hostent->h_name [0] = 0;
960
961 errcode =
962 DNSServiceQueryRecord (
963 &sdref,
964 kDNSServiceFlagsForceMulticast, // force multicast query
965 kDNSServiceInterfaceIndexAny, // all interfaces
966 addr_str, // address string to query for
967 kDNSServiceType_PTR, // pointer RRs
968 kDNSServiceClass_IN, // internet class records
969 mdns_lookup_callback, // callback
970 result // Context - result buffer
971 );
972
973 if (errcode)
974 {
975 syslog (LOG_WARNING,
976 "mdns: Failed to initialise mdns lookup, error %d",
977 errcode
978 );
979 return set_err_mdns_failed (result);
980 }
981
982 status = handle_events (sdref, result, addr_str);
983 DNSServiceRefDeallocate (sdref);
984 return status;
985 }
986
987
988 /*
989 Wait on result of callback, and process it when it arrives.
990
991 Parameters
992 sdref
993 dns-sd reference
994 result
995 Initialised 'result' data structure.
996 str
997 lookup string, used for status/error reporting.
998 */
999 static nss_status
handle_events(DNSServiceRef sdref,result_map_t * result,const char * str)1000 handle_events (DNSServiceRef sdref, result_map_t * result, const char * str)
1001 {
1002 int dns_sd_fd = DNSServiceRefSockFD(sdref);
1003 int nfds = dns_sd_fd + 1;
1004 fd_set readfds;
1005 struct timeval tv;
1006 int select_result;
1007
1008 while (! result->done)
1009 {
1010 FD_ZERO(&readfds);
1011 FD_SET(dns_sd_fd, &readfds);
1012
1013 tv = k_select_time;
1014
1015 select_result =
1016 select (nfds, &readfds, (fd_set*)NULL, (fd_set*)NULL, &tv);
1017 if (select_result > 0)
1018 {
1019 if (FD_ISSET(dns_sd_fd, &readfds))
1020 {
1021 if (MDNS_VERBOSE)
1022 syslog (LOG_DEBUG,
1023 "mdns: Reply received for %s",
1024 str
1025 );
1026 DNSServiceProcessResult(sdref);
1027 }
1028 else
1029 {
1030 syslog (LOG_WARNING,
1031 "mdns: Unexpected return from select on lookup of %s",
1032 str
1033 );
1034 }
1035 }
1036 else
1037 {
1038 // Terminate loop due to timer expiry
1039 if (MDNS_VERBOSE)
1040 syslog (LOG_DEBUG,
1041 "mdns: %s not found - timer expired",
1042 str
1043 );
1044 set_err_notfound (result);
1045 break;
1046 }
1047 }
1048
1049 return result->status;
1050 }
1051
1052
1053 /*
1054 Examine incoming data and add to relevant fields in result structure.
1055 This routine is called from DNSServiceProcessResult where appropriate.
1056 */
1057 void
mdns_lookup_callback(DNSServiceRef sdref,DNSServiceFlags flags,uint32_t interface_index,DNSServiceErrorType error_code,const char * fullname,uint16_t rrtype,uint16_t rrclass,uint16_t rdlen,const void * rdata,uint32_t ttl,void * context)1058 mdns_lookup_callback
1059 (
1060 DNSServiceRef sdref,
1061 DNSServiceFlags flags,
1062 uint32_t interface_index,
1063 DNSServiceErrorType error_code,
1064 const char *fullname,
1065 uint16_t rrtype,
1066 uint16_t rrclass,
1067 uint16_t rdlen,
1068 const void *rdata,
1069 uint32_t ttl,
1070 void *context
1071 )
1072 {
1073 // A single record is received
1074
1075 result_map_t * result = (result_map_t *) context;
1076
1077 (void)sdref; // Unused
1078 (void)interface_index; // Unused
1079 (void)ttl; // Unused
1080
1081 if (! (flags & kDNSServiceFlagsMoreComing) )
1082 {
1083 result->done = 1;
1084 }
1085
1086 if (error_code == kDNSServiceErr_NoError)
1087 {
1088 ns_type_t expected_rr_type =
1089 af_to_rr (result->hostent->h_addrtype);
1090
1091 // Idiot check class
1092 if (rrclass != C_IN)
1093 {
1094 syslog (LOG_WARNING,
1095 "mdns: Received bad RR class: expected %d (%s),"
1096 " got %d (%s), RR type %d (%s)",
1097 C_IN,
1098 ns_class_to_str (C_IN),
1099 rrclass,
1100 ns_class_to_str (rrclass),
1101 rrtype,
1102 ns_type_to_str (rrtype)
1103 );
1104 return;
1105 }
1106
1107 // If a PTR
1108 if (rrtype == kDNSServiceType_PTR)
1109 {
1110 if (callback_body_ptr (fullname, result, rdlen, rdata) < 0)
1111 return;
1112 }
1113 else if (rrtype == expected_rr_type)
1114 {
1115 if (!
1116 add_hostname_or_alias (
1117 result,
1118 fullname,
1119 strlen (fullname)
1120 )
1121 )
1122 {
1123 result->done = 1;
1124 return;
1125 // Abort on error
1126 }
1127
1128 if (! add_address_to_buffer (result, rdata, rdlen) )
1129 {
1130 result->done = 1;
1131 return;
1132 // Abort on error
1133 }
1134 }
1135 else
1136 {
1137 syslog (LOG_WARNING,
1138 "mdns: Received bad RR type: expected %d (%s),"
1139 " got %d (%s)",
1140 expected_rr_type,
1141 ns_type_to_str (expected_rr_type),
1142 rrtype,
1143 ns_type_to_str (rrtype)
1144 );
1145 return;
1146 }
1147
1148 if (result->status != NSS_STATUS_SUCCESS)
1149 set_err_success (result);
1150 }
1151 else
1152 {
1153 // For now, dump message to syslog and continue
1154 syslog (LOG_WARNING,
1155 "mdns: callback returned error %d",
1156 error_code
1157 );
1158 }
1159 }
1160
1161 static int
callback_body_ptr(const char * fullname,result_map_t * result,int rdlen,const void * rdata)1162 callback_body_ptr (
1163 const char * fullname,
1164 result_map_t * result,
1165 int rdlen,
1166 const void * rdata
1167 )
1168 {
1169 char result_name [k_hostname_maxlen + 1];
1170 int rv;
1171
1172 // Fullname should be .in-addr.arpa or equivalent, which we're
1173 // not interested in. Ignore it.
1174
1175 rv = dns_rdata_to_name (rdata, rdlen, result_name, k_hostname_maxlen);
1176 if (rv < 0)
1177 {
1178 const char * errmsg;
1179
1180 switch (rv)
1181 {
1182 case DNS_RDATA_TO_NAME_BAD_FORMAT:
1183 errmsg = "mdns: PTR '%s' result badly formatted ('%s...')";
1184 break;
1185
1186 case DNS_RDATA_TO_NAME_TOO_LONG:
1187 errmsg = "mdns: PTR '%s' result too long ('%s...')";
1188 break;
1189
1190 case DNS_RDATA_TO_NAME_PTR:
1191 errmsg = "mdns: PTR '%s' result contained pointer ('%s...')";
1192 break;
1193
1194 default:
1195 errmsg = "mdns: PTR '%s' result conversion failed ('%s...')";
1196 }
1197
1198 syslog (LOG_WARNING,
1199 errmsg,
1200 fullname,
1201 result_name
1202 );
1203
1204 return -1;
1205 }
1206
1207 if (MDNS_VERBOSE)
1208 {
1209 syslog (LOG_DEBUG,
1210 "mdns: PTR '%s' resolved to '%s'",
1211 fullname,
1212 result_name
1213 );
1214 }
1215
1216 // Data should be a hostname
1217 if (!
1218 add_hostname_or_alias (
1219 result,
1220 result_name,
1221 rv
1222 )
1223 )
1224 {
1225 result->done = 1;
1226 return -1;
1227 }
1228
1229 return 0;
1230 }
1231
1232
1233 /*
1234 Add an address to the buffer.
1235
1236 Parameter
1237 result
1238 Result structure to write to
1239 data
1240 Incoming address data buffer
1241 Must be 'int' aligned
1242 len
1243 Length of data buffer (in bytes)
1244 Must match data alignment
1245
1246 Result
1247 Pointer to start of newly written data,
1248 or NULL on error.
1249 If address already exists in buffer, returns pointer to that instead.
1250 */
1251 static void *
add_address_to_buffer(result_map_t * result,const void * data,int len)1252 add_address_to_buffer (result_map_t * result, const void * data, int len)
1253 {
1254 int new_addr;
1255 void * start;
1256 void * temp;
1257
1258 if ((temp = contains_address (result, data, len)))
1259 {
1260 return temp;
1261 }
1262
1263 if (result->addrs_count >= k_addrs_max)
1264 {
1265 // Not enough addr slots
1266 set_err_internal_resource_full (result);
1267 syslog (LOG_ERR,
1268 "mdns: Internal address buffer full; increase size"
1269 );
1270 return NULL;
1271 }
1272
1273 // Idiot check
1274 if (len != result->hostent->h_length)
1275 {
1276 syslog (LOG_WARNING,
1277 "mdns: Unexpected rdata length for address. Expected %d, got %d",
1278 result->hostent->h_length,
1279 len
1280 );
1281 // XXX And continue for now.
1282 }
1283
1284 new_addr = result->addr_idx + len;
1285
1286 if (new_addr > result->alias_idx)
1287 {
1288 // Not enough room
1289 set_err_buf_too_small (result);
1290 if (MDNS_VERBOSE)
1291 syslog (LOG_DEBUG,
1292 "mdns: Ran out of buffer when adding address %d",
1293 result->addrs_count + 1
1294 );
1295 return NULL;
1296 }
1297
1298 start = result->buffer + result->addr_idx;
1299 memcpy (start, data, len);
1300 result->addr_idx = new_addr;
1301 result->header->addrs [result->addrs_count] = start;
1302 result->addrs_count ++;
1303 result->header->addrs [result->addrs_count] = NULL;
1304
1305 return start;
1306 }
1307
1308
1309 static void *
contains_address(result_map_t * result,const void * data,int len)1310 contains_address (result_map_t * result, const void * data, int len)
1311 {
1312 int i;
1313
1314 // Idiot check
1315 if (len != result->hostent->h_length)
1316 {
1317 syslog (LOG_WARNING,
1318 "mdns: Unexpected rdata length for address. Expected %d, got %d",
1319 result->hostent->h_length,
1320 len
1321 );
1322 // XXX And continue for now.
1323 }
1324
1325 for (i = 0; result->header->addrs [i]; i++)
1326 {
1327 if (memcmp (result->header->addrs [i], data, len) == 0)
1328 {
1329 return result->header->addrs [i];
1330 }
1331 }
1332
1333 return NULL;
1334 }
1335
1336
1337 /*
1338 Add an alias to the buffer.
1339
1340 Parameter
1341 result
1342 Result structure to write to
1343 data
1344 Incoming alias (null terminated)
1345 len
1346 Length of data buffer (in bytes), including trailing null
1347
1348 Result
1349 Pointer to start of newly written data,
1350 or NULL on error
1351 If alias already exists in buffer, returns pointer to that instead.
1352 */
1353 static char *
add_alias_to_buffer(result_map_t * result,const char * data,int len)1354 add_alias_to_buffer (result_map_t * result, const char * data, int len)
1355 {
1356 int new_alias;
1357 char * start;
1358 char * temp;
1359
1360 if ((temp = contains_alias (result, data)))
1361 {
1362 return temp;
1363 }
1364
1365 if (result->aliases_count >= k_aliases_max)
1366 {
1367 // Not enough alias slots
1368 set_err_internal_resource_full (result);
1369 syslog (LOG_ERR,
1370 "mdns: Internal alias buffer full; increase size"
1371 );
1372 return NULL;
1373 }
1374
1375 new_alias = result->alias_idx - len;
1376
1377 if (new_alias < result->addr_idx)
1378 {
1379 // Not enough room
1380 set_err_buf_too_small (result);
1381 if (MDNS_VERBOSE)
1382 syslog (LOG_DEBUG,
1383 "mdns: Ran out of buffer when adding alias %d",
1384 result->aliases_count + 1
1385 );
1386 return NULL;
1387 }
1388
1389 start = result->buffer + new_alias;
1390 memcpy (start, data, len);
1391 result->alias_idx = new_alias;
1392 result->header->aliases [result->aliases_count] = start;
1393 result->aliases_count ++;
1394 result->header->aliases [result->aliases_count] = NULL;
1395
1396 return start;
1397 }
1398
1399
1400 static char *
contains_alias(result_map_t * result,const char * alias)1401 contains_alias (result_map_t * result, const char * alias)
1402 {
1403 int i;
1404
1405 for (i = 0; result->header->aliases [i]; i++)
1406 {
1407 if (strcmp (result->header->aliases [i], alias) == 0)
1408 {
1409 return result->header->aliases [i];
1410 }
1411 }
1412
1413 return NULL;
1414 }
1415
1416
1417 /*
1418 Add fully qualified hostname to result.
1419
1420 Parameter
1421 result
1422 Result structure to write to
1423 fullname
1424 Fully qualified hostname
1425
1426 Result
1427 Pointer to start of hostname buffer,
1428 or NULL on error (usually hostname too long)
1429 */
1430
1431 static char *
add_hostname_len(result_map_t * result,const char * fullname,int len)1432 add_hostname_len (result_map_t * result, const char * fullname, int len)
1433 {
1434 if (len >= k_hostname_maxlen)
1435 {
1436 set_err_bad_hostname (result);
1437 syslog (LOG_WARNING,
1438 "mdns: Hostname too long '%.*s': len %d, max %d",
1439 len,
1440 fullname,
1441 len,
1442 k_hostname_maxlen
1443 );
1444 return NULL;
1445 }
1446
1447 result->hostent->h_name =
1448 strcpy (result->header->hostname, fullname);
1449
1450 return result->header->hostname;
1451 }
1452
1453
1454 /*
1455 Add fully qualified name as hostname or alias.
1456
1457 If hostname is not fully qualified this is not an error, but the data
1458 returned may be not what the application wanted.
1459
1460 Parameter
1461 result
1462 Result structure to write to
1463 data
1464 Incoming alias (null terminated)
1465 len
1466 Length of data buffer (in bytes), including trailing null
1467
1468 Result
1469 Pointer to start of newly written data,
1470 or NULL on error
1471 If alias or hostname already exists, returns pointer to that instead.
1472 */
1473 static char *
add_hostname_or_alias(result_map_t * result,const char * data,int len)1474 add_hostname_or_alias (result_map_t * result, const char * data, int len)
1475 {
1476 char * hostname = result->hostent->h_name;
1477
1478 if (*hostname)
1479 {
1480 if (strcmp (hostname, data) == 0)
1481 {
1482 return hostname;
1483 }
1484 else
1485 {
1486 return add_alias_to_buffer (result, data, len);
1487 }
1488 }
1489 else
1490 {
1491 return add_hostname_len (result, data, len);
1492 }
1493 }
1494
1495
1496 static int
init_result(result_map_t * result,hostent * result_buf,char * buf,size_t buflen)1497 init_result (
1498 result_map_t * result,
1499 hostent * result_buf,
1500 char * buf,
1501 size_t buflen
1502 )
1503 {
1504 if (buflen < sizeof (buf_header_t))
1505 {
1506 return ERANGE;
1507 }
1508
1509 result->hostent = result_buf;
1510 result->header = (buf_header_t *) buf;
1511 result->header->hostname[0] = 0;
1512 result->aliases_count = 0;
1513 result->header->aliases[0] = NULL;
1514 result->addrs_count = 0;
1515 result->header->addrs[0] = NULL;
1516 result->buffer = buf + sizeof (buf_header_t);
1517 result->addr_idx = 0;
1518 result->alias_idx = buflen - sizeof (buf_header_t);
1519 result->done = 0;
1520 set_err_notfound (result);
1521
1522 // Point hostent to the right buffers
1523 result->hostent->h_name = result->header->hostname;
1524 result->hostent->h_aliases = result->header->aliases;
1525 result->hostent->h_addr_list = result->header->addrs;
1526
1527 return 0;
1528 }
1529
1530 /*
1531 Set the status in the result.
1532
1533 Parameters
1534 result
1535 Result structure to update
1536 status
1537 New nss_status value
1538 err
1539 New errno value
1540 herr
1541 New h_errno value
1542
1543 Returns
1544 New status value
1545 */
1546 static nss_status
set_err(result_map_t * result,nss_status status,int err,int herr)1547 set_err (result_map_t * result, nss_status status, int err, int herr)
1548 {
1549 result->status = status;
1550 result->r_errno = err;
1551 result->r_h_errno = herr;
1552
1553 return status;
1554 }
1555
1556 static nss_status
set_err_notfound(result_map_t * result)1557 set_err_notfound (result_map_t * result)
1558 {
1559 return set_err (result, NSS_STATUS_NOTFOUND, ENOENT, HOST_NOT_FOUND);
1560 }
1561
1562 static nss_status
set_err_bad_hostname(result_map_t * result)1563 set_err_bad_hostname (result_map_t * result)
1564 {
1565 return set_err (result, NSS_STATUS_TRYAGAIN, ENOENT, NO_RECOVERY);
1566 }
1567
1568 static nss_status
set_err_buf_too_small(result_map_t * result)1569 set_err_buf_too_small (result_map_t * result)
1570 {
1571 return set_err (result, NSS_STATUS_TRYAGAIN, ERANGE, NETDB_INTERNAL);
1572 }
1573
1574 static nss_status
set_err_internal_resource_full(result_map_t * result)1575 set_err_internal_resource_full (result_map_t * result)
1576 {
1577 return set_err (result, NSS_STATUS_RETURN, ERANGE, NO_RECOVERY);
1578 }
1579
1580 static nss_status
set_err_system(result_map_t * result)1581 set_err_system (result_map_t * result)
1582 {
1583 return set_err (result, NSS_STATUS_UNAVAIL, errno, NETDB_INTERNAL);
1584 }
1585
1586 static nss_status
set_err_mdns_failed(result_map_t * result)1587 set_err_mdns_failed (result_map_t * result)
1588 {
1589 return set_err (result, NSS_STATUS_TRYAGAIN, EAGAIN, TRY_AGAIN);
1590 }
1591
1592 static nss_status
set_err_success(result_map_t * result)1593 set_err_success (result_map_t * result)
1594 {
1595 result->status = NSS_STATUS_SUCCESS;
1596 return result->status;
1597 }
1598
1599
1600 /*
1601 Test whether name is applicable for mdns to process, and if so copy into
1602 lookup_name buffer (if non-NULL).
1603
1604 Returns
1605 Pointer to name to lookup up, if applicable, or NULL otherwise.
1606 */
1607 static const char *
is_applicable_name(result_map_t * result,const char * name,char * lookup_name)1608 is_applicable_name (
1609 result_map_t * result,
1610 const char * name,
1611 char * lookup_name
1612 )
1613 {
1614 int match = config_is_mdns_suffix (name);
1615 if (match > 0)
1616 {
1617 if (lookup_name)
1618 {
1619 strncpy (lookup_name, name, k_hostname_maxlen + 1);
1620 return lookup_name;
1621 }
1622 else
1623 {
1624 return name;
1625 }
1626 }
1627 else
1628 {
1629 if (match < 0)
1630 {
1631 set_err_system (result);
1632 }
1633 return NULL;
1634 }
1635 }
1636
1637 /*
1638 Test whether address is applicable for mdns to process, and if so copy into
1639 addr_str buffer as an address suitable for ptr lookup.
1640
1641 Returns
1642 Pointer to name to lookup up, if applicable, or NULL otherwise.
1643 */
1644 static const char *
is_applicable_addr(result_map_t * result,const void * addr,int af,char * addr_str)1645 is_applicable_addr (
1646 result_map_t * result,
1647 const void * addr,
1648 int af,
1649 char * addr_str
1650 )
1651 {
1652 int match;
1653
1654 if (! format_reverse_addr (af, addr, -1, addr_str))
1655 {
1656 if (MDNS_VERBOSE)
1657 syslog (LOG_DEBUG,
1658 "mdns: Failed to create reverse address"
1659 );
1660 return NULL;
1661 }
1662
1663 if (MDNS_VERBOSE)
1664 syslog (LOG_DEBUG,
1665 "mdns: Reverse address: %s",
1666 addr_str
1667 );
1668
1669 match = config_is_mdns_suffix (addr_str);
1670 if (match > 0)
1671 {
1672 return addr_str;
1673 }
1674 else
1675 {
1676 if (match < 0)
1677 {
1678 set_err_system (result);
1679 }
1680 return NULL;
1681 }
1682 }
1683
1684 //----------
1685 // Types and Constants
1686
1687 const char * k_conf_file = "/etc/nss_mdns.conf";
1688 #define CONF_LINE_SIZE 1024
1689
1690 const char k_comment_char = '#';
1691
1692 const char * k_keyword_domain = "domain";
1693
1694 const char * k_default_domains [] =
1695 {
1696 "local",
1697 "254.169.in-addr.arpa",
1698 "8.e.f.ip6.int",
1699 "8.e.f.ip6.arpa",
1700 "9.e.f.ip6.int",
1701 "9.e.f.ip6.arpa",
1702 "a.e.f.ip6.int",
1703 "a.e.f.ip6.arpa",
1704 "b.e.f.ip6.int",
1705 "b.e.f.ip6.arpa",
1706 NULL
1707 // Always null terminated
1708 };
1709
1710 // Linked list of domains
1711 typedef struct domain_entry
1712 {
1713 char * domain;
1714 struct domain_entry * next;
1715 } domain_entry_t;
1716
1717
1718 // Config
1719 typedef struct
1720 {
1721 domain_entry_t * domains;
1722 } config_t;
1723
1724 const config_t k_empty_config =
1725 {
1726 NULL
1727 };
1728
1729
1730 // Context - tracks position in config file, used for error reporting
1731 typedef struct
1732 {
1733 const char * filename;
1734 int linenum;
1735 } config_file_context_t;
1736
1737
1738 //----------
1739 // Local prototypes
1740
1741 static errcode_t
1742 load_config (config_t * conf);
1743
1744 static errcode_t
1745 process_config_line (
1746 config_t * conf,
1747 char * line,
1748 config_file_context_t * context
1749 );
1750
1751 static char *
1752 get_next_word (char * input, char **next);
1753
1754 static errcode_t
1755 default_config (config_t * conf);
1756
1757 static errcode_t
1758 add_domain (config_t * conf, const char * domain);
1759
1760 static int
1761 contains_domain (const config_t * conf, const char * domain);
1762
1763 static int
1764 contains_domain_suffix (const config_t * conf, const char * addr);
1765
1766
1767 //----------
1768 // Global variables
1769
1770 static config_t * g_config = NULL;
1771 // Configuration info
1772
1773 pthread_mutex_t g_config_mutex =
1774 #ifdef PTHREAD_ERRORCHECK_MUTEX_INITIALIZER_NP
1775 PTHREAD_ERRORCHECK_MUTEX_INITIALIZER_NP;
1776 #else
1777 PTHREAD_MUTEX_INITIALIZER;
1778 #endif
1779
1780
1781 //----------
1782 // Configuration functions
1783
1784
1785 /*
1786 Initialise the configuration from the config file.
1787
1788 Returns
1789 0 success
1790 non-zero error code on failure
1791 */
1792 errcode_t
init_config()1793 init_config ()
1794 {
1795 if (g_config)
1796 {
1797 /*
1798 Safe to test outside mutex.
1799 If non-zero, initialisation is complete and g_config can be
1800 safely used read-only. If zero, then we do proper mutex
1801 testing before initialisation.
1802 */
1803 return 0;
1804 }
1805 else
1806 {
1807 int errcode = -1;
1808 int presult;
1809 config_t * temp_config;
1810
1811 // Acquire mutex
1812 presult = pthread_mutex_lock (&g_config_mutex);
1813 if (presult)
1814 {
1815 syslog (LOG_ERR,
1816 "mdns: Fatal mutex lock error in nss_mdns:init_config, %s:%d: %d: %s",
1817 __FILE__, __LINE__, presult, strerror (presult)
1818 );
1819 return presult;
1820 }
1821
1822 // Test again now we have mutex, in case initialisation occurred while
1823 // we were waiting
1824 if (! g_config)
1825 {
1826 temp_config = (config_t *) malloc (sizeof (config_t));
1827 if (temp_config)
1828 {
1829 // Note: This code will leak memory if initialisation fails
1830 // repeatedly. This should only happen in the case of a memory
1831 // error, so I'm not sure if it's a meaningful problem. - AW
1832 *temp_config = k_empty_config;
1833 errcode = load_config (temp_config);
1834
1835 if (! errcode)
1836 {
1837 g_config = temp_config;
1838 }
1839 }
1840 else
1841 {
1842 syslog (LOG_ERR,
1843 "mdns: Can't allocate memory in nss_mdns:init_config, %s:%d",
1844 __FILE__, __LINE__
1845 );
1846 errcode = errno;
1847 }
1848 }
1849
1850 presult = pthread_mutex_unlock (&g_config_mutex);
1851 if (presult)
1852 {
1853 syslog (LOG_ERR,
1854 "mdns: Fatal mutex unlock error in nss_mdns:init_config, %s:%d: %d: %s",
1855 __FILE__, __LINE__, presult, strerror (presult)
1856 );
1857 errcode = presult;
1858 }
1859
1860 return errcode;
1861 }
1862 }
1863
1864
1865 int
config_is_mdns_suffix(const char * name)1866 config_is_mdns_suffix (const char * name)
1867 {
1868 int errcode = init_config ();
1869 if (! errcode)
1870 {
1871 return contains_domain_suffix (g_config, name);
1872 }
1873 else
1874 {
1875 errno = errcode;
1876 return -1;
1877 }
1878 }
1879
1880
1881 //----------
1882 // Local functions
1883
1884 static errcode_t
load_config(config_t * conf)1885 load_config (config_t * conf)
1886 {
1887 FILE * cf;
1888 char line [CONF_LINE_SIZE];
1889 config_file_context_t context;
1890
1891 context.filename = k_conf_file;
1892 context.linenum = 0;
1893
1894
1895 cf = fopen (context.filename, "r");
1896 if (! cf)
1897 {
1898 syslog (LOG_INFO,
1899 "mdns: Couldn't open nss_mdns configuration file %s, using default.",
1900 context.filename
1901 );
1902 return default_config (conf);
1903 }
1904
1905 while (fgets (line, CONF_LINE_SIZE, cf))
1906 {
1907 int errcode;
1908 context.linenum++;
1909 errcode = process_config_line (conf, line, &context);
1910 if (errcode)
1911 {
1912 // Critical error, give up
1913 fclose(cf);
1914 return errcode;
1915 }
1916 }
1917
1918 fclose (cf);
1919
1920 return 0;
1921 }
1922
1923
1924 /*
1925 Parse a line of the configuration file.
1926 For each keyword recognised, perform appropriate handling.
1927 If the keyword is not recognised, print a message to syslog
1928 and continue.
1929
1930 Returns
1931 0 success, or recoverable config file error
1932 non-zero serious system error, processing aborted
1933 */
1934 static errcode_t
process_config_line(config_t * conf,char * line,config_file_context_t * context)1935 process_config_line (
1936 config_t * conf,
1937 char * line,
1938 config_file_context_t * context
1939 )
1940 {
1941 char * curr = line;
1942 char * word;
1943
1944 word = get_next_word (curr, &curr);
1945 if (! word || word [0] == k_comment_char)
1946 {
1947 // Nothing interesting on this line
1948 return 0;
1949 }
1950
1951 if (strcmp (word, k_keyword_domain) == 0)
1952 {
1953 word = get_next_word (curr, &curr);
1954 if (word)
1955 {
1956 int errcode = add_domain (conf, word);
1957 if (errcode)
1958 {
1959 // something badly wrong, bail
1960 return errcode;
1961 }
1962
1963 if (get_next_word (curr, NULL))
1964 {
1965 syslog (LOG_WARNING,
1966 "%s, line %d: ignored extra text found after domain",
1967 context->filename,
1968 context->linenum
1969 );
1970 }
1971 }
1972 else
1973 {
1974 syslog (LOG_WARNING,
1975 "%s, line %d: no domain specified",
1976 context->filename,
1977 context->linenum
1978 );
1979 }
1980 }
1981 else
1982 {
1983 syslog (LOG_WARNING,
1984 "%s, line %d: unknown keyword %s - skipping",
1985 context->filename,
1986 context->linenum,
1987 word
1988 );
1989 }
1990
1991 return 0;
1992 }
1993
1994
1995 /*
1996 Get next word (whitespace separated) from input string.
1997 A null character is written into the first whitespace character following
1998 the word.
1999
2000 Parameters
2001 input
2002 Input string. This string is modified by get_next_word.
2003 next
2004 If non-NULL and the result is non-NULL, a pointer to the
2005 character following the end of the word (after the null)
2006 is written to 'next'.
2007 If no word is found, the original value is unchanged.
2008 If the word extended to the end of the string, 'next' points
2009 to the trailling NULL.
2010 It is safe to pass 'str' as 'input' and '&str' as 'next'.
2011 Returns
2012 Pointer to the first non-whitespace character (and thus word) found.
2013 if no word is found, returns NULL.
2014 */
2015 static char *
get_next_word(char * input,char ** next)2016 get_next_word (char * input, char **next)
2017 {
2018 char * curr = input;
2019 char * result;
2020
2021 while (isspace (*curr))
2022 {
2023 curr ++;
2024 }
2025
2026 if (*curr == 0)
2027 {
2028 return NULL;
2029 }
2030
2031 result = curr;
2032 while (*curr && ! isspace (*curr))
2033 {
2034 curr++;
2035 }
2036 if (*curr)
2037 {
2038 *curr = 0;
2039 if (next)
2040 {
2041 *next = curr+1;
2042 }
2043 }
2044 else
2045 {
2046 if (next)
2047 {
2048 *next = curr;
2049 }
2050 }
2051
2052 return result;
2053 }
2054
2055
2056 static errcode_t
default_config(config_t * conf)2057 default_config (config_t * conf)
2058 {
2059 int i;
2060 for (i = 0; k_default_domains [i]; i++)
2061 {
2062 int errcode =
2063 add_domain (conf, k_default_domains [i]);
2064 if (errcode)
2065 {
2066 // Something has gone (badly) wrong - let's bail
2067 return errcode;
2068 }
2069 }
2070
2071 return 0;
2072 }
2073
2074
2075 static errcode_t
add_domain(config_t * conf,const char * domain)2076 add_domain (config_t * conf, const char * domain)
2077 {
2078 if (! contains_domain (conf, domain))
2079 {
2080 domain_entry_t * d =
2081 (domain_entry_t *) malloc (sizeof (domain_entry_t));
2082 if (! d)
2083 {
2084 syslog (LOG_ERR,
2085 "mdns: Can't allocate memory in nss_mdns:init_config, %s:%d",
2086 __FILE__, __LINE__
2087 );
2088 return ENOMEM;
2089 }
2090
2091 d->domain = strdup (domain);
2092 if (! d->domain)
2093 {
2094 syslog (LOG_ERR,
2095 "mdns: Can't allocate memory in nss_mdns:init_config, %s:%d",
2096 __FILE__, __LINE__
2097 );
2098 free (d);
2099 return ENOMEM;
2100 }
2101 d->next = conf->domains;
2102 conf->domains = d;
2103 }
2104
2105 return 0;
2106 }
2107
2108
2109 static int
contains_domain(const config_t * conf,const char * domain)2110 contains_domain (const config_t * conf, const char * domain)
2111 {
2112 const domain_entry_t * curr = conf->domains;
2113
2114 while (curr != NULL)
2115 {
2116 if (strcasecmp (curr->domain, domain) == 0)
2117 {
2118 return 1;
2119 }
2120
2121 curr = curr->next;
2122 }
2123
2124 return 0;
2125 }
2126
2127
2128 static int
contains_domain_suffix(const config_t * conf,const char * addr)2129 contains_domain_suffix (const config_t * conf, const char * addr)
2130 {
2131 const domain_entry_t * curr = conf->domains;
2132
2133 while (curr != NULL)
2134 {
2135 if (cmp_dns_suffix (addr, curr->domain) > 0)
2136 {
2137 return 1;
2138 }
2139
2140 curr = curr->next;
2141 }
2142
2143 return 0;
2144 }
2145
2146 //----------
2147 // Types and Constants
2148
2149 static const char * k_local_suffix = "local";
2150 static const char k_dns_separator = '.';
2151
2152 static const int k_label_maxlen = DNS_LABEL_MAXLEN;
2153 // Label entries longer than this are actually pointers.
2154
2155 typedef struct
2156 {
2157 int value;
2158 const char * name;
2159 const char * comment;
2160 } table_entry_t;
2161
2162 static const table_entry_t k_table_af [] =
2163 {
2164 { AF_UNSPEC, NULL, NULL },
2165 { AF_LOCAL, "LOCAL", NULL },
2166 { AF_UNIX, "UNIX", NULL },
2167 { AF_INET, "INET", NULL },
2168 { AF_INET6, "INET6", NULL }
2169 };
2170 static const int k_table_af_size =
2171 sizeof (k_table_af) / sizeof (* k_table_af);
2172
2173 static const char * k_table_ns_class [] =
2174 {
2175 NULL,
2176 "IN"
2177 };
2178 static const int k_table_ns_class_size =
2179 sizeof (k_table_ns_class) / sizeof (* k_table_ns_class);
2180
2181 static const char * k_table_ns_type [] =
2182 {
2183 NULL,
2184 "A",
2185 "NS",
2186 "MD",
2187 "MF",
2188 "CNAME",
2189 "SOA",
2190 "MB",
2191 "MG",
2192 "MR",
2193 "NULL",
2194 "WKS",
2195 "PTR",
2196 "HINFO",
2197 "MINFO",
2198 "MX",
2199 "TXT",
2200 "RP",
2201 "AFSDB",
2202 "X25",
2203 "ISDN",
2204 "RT",
2205 "NSAP",
2206 NULL,
2207 "SIG",
2208 "KEY",
2209 "PX",
2210 "GPOS",
2211 "AAAA",
2212 "LOC",
2213 "NXT",
2214 "EID",
2215 "NIMLOC",
2216 "SRV",
2217 "ATMA",
2218 "NAPTR",
2219 "KX",
2220 "CERT",
2221 "A6",
2222 "DNAME",
2223 "SINK",
2224 "OPT"
2225 };
2226 static const int k_table_ns_type_size =
2227 sizeof (k_table_ns_type) / sizeof (* k_table_ns_type);
2228
2229
2230 //----------
2231 // Local prototypes
2232
2233 static int
2234 simple_table_index (const char * table [], int size, const char * str);
2235
2236 static int
2237 table_index_name (const table_entry_t table [], int size, const char * str);
2238
2239 static int
2240 table_index_value (const table_entry_t table [], int size, int n);
2241
2242
2243 //----------
2244 // Global variables
2245
2246
2247 //----------
2248 // Util functions
2249
2250 int
count_dots(const char * name)2251 count_dots (const char * name)
2252 {
2253 int count = 0;
2254 int i;
2255 for (i = 0; name[i]; i++)
2256 {
2257 if (name [i] == k_dns_separator)
2258 count++;
2259 }
2260
2261 return count;
2262 }
2263
2264
2265 int
islocal(const char * name)2266 islocal (const char * name)
2267 {
2268 return cmp_dns_suffix (name, k_local_suffix) > 0;
2269 }
2270
2271
2272 int
rr_to_af(ns_type_t rrtype)2273 rr_to_af (ns_type_t rrtype)
2274 {
2275 switch (rrtype)
2276 {
2277 case kDNSServiceType_A:
2278 return AF_INET;
2279
2280 case kDNSServiceType_AAAA:
2281 return AF_INET6;
2282
2283 default:
2284 return AF_UNSPEC;
2285 }
2286 }
2287
2288
2289 ns_type_t
af_to_rr(int af)2290 af_to_rr (int af)
2291 {
2292 switch (af)
2293 {
2294 case AF_INET:
2295 return kDNSServiceType_A;
2296
2297 case AF_INET6:
2298 return kDNSServiceType_AAAA;
2299
2300 default:
2301 //return ns_t_invalid;
2302 return 0;
2303 }
2304 }
2305
2306
2307 int
str_to_af(const char * str)2308 str_to_af (const char * str)
2309 {
2310 int result =
2311 table_index_name (k_table_af, k_table_af_size, str);
2312 if (result < 0)
2313 result = 0;
2314
2315 return k_table_af [result].value;
2316 }
2317
2318
2319 ns_class_t
str_to_ns_class(const char * str)2320 str_to_ns_class (const char * str)
2321 {
2322 return (ns_class_t)
2323 simple_table_index (k_table_ns_class, k_table_ns_class_size, str);
2324 }
2325
2326
2327 ns_type_t
str_to_ns_type(const char * str)2328 str_to_ns_type (const char * str)
2329 {
2330 return (ns_type_t)
2331 simple_table_index (k_table_ns_type, k_table_ns_type_size, str);
2332 }
2333
2334
2335 const char *
af_to_str(int in)2336 af_to_str (int in)
2337 {
2338 int result =
2339 table_index_value (k_table_af, k_table_af_size, in);
2340 if (result < 0)
2341 result = 0;
2342
2343 return k_table_af [result].name;
2344 }
2345
2346
2347 const char *
ns_class_to_str(ns_class_t in)2348 ns_class_to_str (ns_class_t in)
2349 {
2350 if (in < k_table_ns_class_size)
2351 return k_table_ns_class [in];
2352 else
2353 return NULL;
2354 }
2355
2356
2357 const char *
ns_type_to_str(ns_type_t in)2358 ns_type_to_str (ns_type_t in)
2359 {
2360 if (in < k_table_ns_type_size)
2361 return k_table_ns_type [in];
2362 else
2363 return NULL;
2364 }
2365
2366
2367 char *
format_reverse_addr_in(const struct in_addr * addr,int prefixlen,char * buf)2368 format_reverse_addr_in (
2369 const struct in_addr * addr,
2370 int prefixlen,
2371 char * buf
2372 )
2373 {
2374 char * curr = buf;
2375 int i;
2376
2377 const uint8_t * in_addr_a = (uint8_t *) addr;
2378
2379 if (prefixlen > 32)
2380 return NULL;
2381 if (prefixlen < 0)
2382 prefixlen = 32;
2383
2384 i = (prefixlen + 7) / 8;
2385 // divide prefixlen into bytes, rounding up
2386
2387 while (i > 0)
2388 {
2389 i--;
2390 curr += sprintf (curr, "%d.", in_addr_a [i]);
2391 }
2392 sprintf (curr, "in-addr.arpa");
2393
2394 return buf;
2395 }
2396
2397
2398 char *
format_reverse_addr_in6(const struct in6_addr * addr,int prefixlen,char * buf)2399 format_reverse_addr_in6 (
2400 const struct in6_addr * addr,
2401 int prefixlen,
2402 char * buf
2403 )
2404 {
2405 char * curr = buf;
2406 int i;
2407
2408 const uint8_t * in_addr_a = (uint8_t *) addr;
2409
2410 if (prefixlen > 128)
2411 return NULL;
2412 if (prefixlen < 0)
2413 prefixlen = 128;
2414
2415 i = (prefixlen + 3) / 4;
2416 // divide prefixlen into nibbles, rounding up
2417
2418 // Special handling for first
2419 if (i % 2)
2420 {
2421 curr += sprintf (curr, "%d.", (in_addr_a [i/2] >> 4) & 0x0F);
2422 }
2423 i >>= 1;
2424 // Convert i to bytes (divide by 2)
2425
2426 while (i > 0)
2427 {
2428 uint8_t val;
2429
2430 i--;
2431 val = in_addr_a [i];
2432 curr += sprintf (curr, "%x.%x.", val & 0x0F, (val >> 4) & 0x0F);
2433 }
2434 sprintf (curr, "ip6.arpa");
2435
2436 return buf;
2437 }
2438
2439
2440 char *
format_reverse_addr(int af,const void * addr,int prefixlen,char * buf)2441 format_reverse_addr (
2442 int af,
2443 const void * addr,
2444 int prefixlen,
2445 char * buf
2446 )
2447 {
2448 switch (af)
2449 {
2450 case AF_INET:
2451 return
2452 format_reverse_addr_in (
2453 (struct in_addr *) addr, prefixlen, buf
2454 );
2455 break;
2456
2457 case AF_INET6:
2458 return
2459 format_reverse_addr_in6 (
2460 (struct in6_addr *) addr, prefixlen, buf
2461 );
2462 break;
2463
2464 default:
2465 return NULL;
2466 }
2467 }
2468
2469
2470 int
cmp_dns_suffix(const char * name,const char * domain)2471 cmp_dns_suffix (const char * name, const char * domain)
2472 {
2473 const char * nametail;
2474 const char * domaintail;
2475
2476 // Idiot checks
2477 if (*name == 0 || *name == k_dns_separator)
2478 {
2479 // Name can't be empty or start with separator
2480 return CMP_DNS_SUFFIX_BAD_NAME;
2481 }
2482
2483 if (*domain == 0)
2484 {
2485 return CMP_DNS_SUFFIX_SUCCESS;
2486 // trivially true
2487 }
2488
2489 if (*domain == k_dns_separator)
2490 {
2491 // drop leading separator from domain
2492 domain++;
2493 if (*domain == k_dns_separator)
2494 {
2495 return CMP_DNS_SUFFIX_BAD_DOMAIN;
2496 }
2497 }
2498
2499 // Find ends of strings
2500 for (nametail = name; *nametail; nametail++)
2501 ;
2502 for (domaintail = domain; *domaintail; domaintail++)
2503 ;
2504
2505 // Shuffle back to last real character, and drop any trailing '.'
2506 // while we're at it.
2507 nametail --;
2508 if (*nametail == k_dns_separator)
2509 {
2510 nametail --;
2511 if (*nametail == k_dns_separator)
2512 {
2513 return CMP_DNS_SUFFIX_BAD_NAME;
2514 }
2515 }
2516 domaintail --;
2517 if (*domaintail == k_dns_separator)
2518 {
2519 domaintail --;
2520 if (*domaintail == k_dns_separator)
2521 {
2522 return CMP_DNS_SUFFIX_BAD_DOMAIN;
2523 }
2524 }
2525
2526 // Compare.
2527 while (
2528 nametail >= name
2529 && domaintail >= domain
2530 && tolower(*nametail) == tolower(*domaintail))
2531 {
2532 nametail--;
2533 domaintail--;
2534 }
2535
2536 /* A successful finish will be one of the following:
2537 (leading and trailing . ignored)
2538
2539 name : domain2.domain1
2540 domain: domain2.domain1
2541 ^
2542
2543 name : domain3.domain2.domain1
2544 domain: domain2.domain1
2545 ^
2546 */
2547 if (
2548 domaintail < domain
2549 && (nametail < name || *nametail == k_dns_separator)
2550 )
2551 {
2552 return CMP_DNS_SUFFIX_SUCCESS;
2553 }
2554 else
2555 {
2556 return CMP_DNS_SUFFIX_FAILURE;
2557 }
2558 }
2559
2560
2561 int
dns_rdata_to_name(const char * rdata,int rdlen,char * name,int name_len)2562 dns_rdata_to_name (const char * rdata, int rdlen, char * name, int name_len)
2563 {
2564 int i = 0;
2565 // Index into 'name'
2566 const char * rdata_curr = rdata;
2567
2568 if (rdlen == 0) return DNS_RDATA_TO_NAME_BAD_FORMAT;
2569
2570 /*
2571 In RDATA, a DNS name is stored as a series of labels.
2572 Each label consists of a length octet (max value 63)
2573 followed by the data for that label.
2574 The series is terminated with a length 0 octet.
2575 A length octet beginning with bits 11 is a pointer to
2576 somewhere else in the payload, but we don't support these
2577 since we don't have access to the entire payload.
2578
2579 See RFC1034 section 3.1 and RFC1035 section 3.1.
2580 */
2581 while (1)
2582 {
2583 int term_len = *rdata_curr;
2584 rdata_curr++;
2585
2586 if (term_len == 0)
2587 {
2588 break;
2589 // 0 length record terminates label
2590 }
2591 else if (term_len > k_label_maxlen)
2592 {
2593 name [i] = 0;
2594 return DNS_RDATA_TO_NAME_PTR;
2595 }
2596 else if (rdata_curr + term_len > rdata + rdlen)
2597 {
2598 name [i] = 0;
2599 return DNS_RDATA_TO_NAME_BAD_FORMAT;
2600 }
2601
2602 if (name_len < i + term_len + 1)
2603 // +1 is separator
2604 {
2605 name [i] = 0;
2606 return DNS_RDATA_TO_NAME_TOO_LONG;
2607 }
2608
2609 memcpy (name + i, rdata_curr, term_len);
2610
2611 i += term_len;
2612 rdata_curr += term_len;
2613
2614 name [i] = k_dns_separator;
2615 i++;
2616 }
2617
2618 name [i] = 0;
2619 return i;
2620 }
2621
2622
2623 //----------
2624 // Local functions
2625
2626 /*
2627 Find the index of an string entry in a table. A case insenitive match
2628 is performed. If no entry is found, 0 is returned.
2629
2630 Parameters
2631 table
2632 Lookup table
2633 Table entries may be NULL. NULL entries will never match.
2634 size
2635 number of entries in table
2636 str
2637 lookup string
2638
2639 Result
2640 index of first matching entry, or 0 if no matches
2641 */
2642 static int
simple_table_index(const char * table[],int size,const char * str)2643 simple_table_index (const char * table [], int size, const char * str)
2644 {
2645 int i;
2646 for (i = 0; i < size; i++)
2647 {
2648 if (
2649 table [i]
2650 && (strcasecmp (table [i], str) == 0)
2651 )
2652 {
2653 return i;
2654 }
2655 }
2656
2657 return 0;
2658 }
2659
2660
2661 /*
2662 Find the index of a name in a table.
2663
2664 Parameters
2665 table
2666 array of table_entry_t records. The name field is compared
2667 (ignoring case) to the input string.
2668 size
2669 number of entries in table
2670 str
2671 lookup string
2672
2673 Result
2674 index of first matching entry, or -1 if no matches
2675 */
2676 static int
table_index_name(const table_entry_t table[],int size,const char * str)2677 table_index_name (const table_entry_t table [], int size, const char * str)
2678 {
2679 int i;
2680 for (i = 0; i < size; i++)
2681 {
2682 if (
2683 table [i].name
2684 && (strcasecmp (table [i].name, str) == 0)
2685 )
2686 {
2687 return i;
2688 }
2689 }
2690
2691 return -1;
2692 }
2693
2694
2695 /*
2696 Find the index of a value a table.
2697
2698 Parameters
2699 table
2700 array of table_entry_t records. The value field is compared to
2701 the input value
2702 size
2703 number of entries in table
2704 n
2705 lookup value
2706
2707 Result
2708 index of first matching entry, or -1 if no matches
2709 */
2710 static int
table_index_value(const table_entry_t table[],int size,int n)2711 table_index_value (const table_entry_t table [], int size, int n)
2712 {
2713 int i;
2714 for (i = 0; i < size; i++)
2715 {
2716 if (table [i].value == n)
2717 {
2718 return i;
2719 }
2720 }
2721
2722 return -1;
2723 }
2724