2 This file is part of systemd.
4 Copyright 2017 Dmitry Rozhkov
6 systemd is free software; you can redistribute it and/or modify it
7 under the terms of the GNU Lesser General Public License as published by
8 the Free Software Foundation; either version 2.1 of the License, or
9 (at your option) any later version.
11 systemd is distributed in the hope that it will be useful, but
12 WITHOUT ANY WARRANTY; without even the implied warranty of
13 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14 Lesser General Public License for more details.
16 You should have received a copy of the GNU Lesser General Public License
17 along with systemd; If not, see <http://www.gnu.org/licenses/>.
20 #include "conf-files.h"
21 #include "conf-parser.h"
22 #include "resolved-dnssd.h"
23 #include "resolved-dns-rr.h"
24 #include "resolved-manager.h"
25 #include "specifier.h"
28 const char* const dnssd_service_dirs
[] = {
31 "/usr/lib/systemd/dnssd",
38 DnssdTxtData
*dnssd_txtdata_free(DnssdTxtData
*txt_data
) {
42 dns_resource_record_unref(txt_data
->rr
);
43 dns_txt_item_free_all(txt_data
->txt
);
45 return mfree(txt_data
);
48 DnssdTxtData
*dnssd_txtdata_free_all(DnssdTxtData
*txt_data
) {
54 next
= txt_data
->items_next
;
56 dnssd_txtdata_free(txt_data
);
58 return dnssd_txtdata_free_all(next
);
61 DnssdService
*dnssd_service_free(DnssdService
*service
) {
66 hashmap_remove(service
->manager
->dnssd_services
, service
->name
);
68 dns_resource_record_unref(service
->ptr_rr
);
69 dns_resource_record_unref(service
->srv_rr
);
71 dnssd_txtdata_free_all(service
->txt_data_items
);
73 free(service
->filename
);
76 free(service
->name_template
);
78 return mfree(service
);
81 static int dnssd_service_load(Manager
*manager
, const char *filename
) {
82 _cleanup_(dnssd_service_freep
) DnssdService
*service
= NULL
;
83 _cleanup_(dnssd_txtdata_freep
) DnssdTxtData
*txt_data
= NULL
;
85 const char *dropin_dirname
;
91 service
= new0(DnssdService
, 1);
95 service
->filename
= strdup(filename
);
96 if (!service
->filename
)
99 service
->name
= strdup(basename(filename
));
103 d
= endswith(service
->name
, ".dnssd");
107 assert(streq(d
, ".dnssd"));
111 dropin_dirname
= strjoina(service
->name
, ".dnssd.d");
113 r
= config_parse_many(filename
, dnssd_service_dirs
, dropin_dirname
,
115 config_item_perf_lookup
, resolved_dnssd_gperf_lookup
,
120 if (!service
->name_template
) {
121 log_error("%s doesn't define service instance name", service
->name
);
125 if (!service
->type
) {
126 log_error("%s doesn't define service type", service
->name
);
130 if (LIST_IS_EMPTY(service
->txt_data_items
)) {
131 txt_data
= new0(DnssdTxtData
, 1);
135 r
= dns_txt_item_new_empty(&txt_data
->txt
);
139 LIST_PREPEND(items
, service
->txt_data_items
, txt_data
);
143 r
= hashmap_ensure_allocated(&manager
->dnssd_services
, &string_hash_ops
);
147 r
= hashmap_put(manager
->dnssd_services
, service
->name
, service
);
151 service
->manager
= manager
;
153 r
= dnssd_update_rrs(service
);
162 static int specifier_dnssd_host_name(char specifier
, void *data
, void *userdata
, char **ret
) {
163 DnssdService
*s
= (DnssdService
*) userdata
;
168 assert(s
->manager
->llmnr_hostname
);
170 n
= strdup(s
->manager
->llmnr_hostname
);
178 int dnssd_render_instance_name(DnssdService
*s
, char **ret_name
) {
179 static const Specifier specifier_table
[] = {
180 { 'b', specifier_boot_id
, NULL
},
181 { 'H', specifier_dnssd_host_name
, NULL
},
182 { 'm', specifier_machine_id
, NULL
},
183 { 'v', specifier_kernel_release
, NULL
},
186 _cleanup_free_
char *name
= NULL
;
190 assert(s
->name_template
);
192 r
= specifier_printf(s
->name_template
, specifier_table
, s
, &name
);
194 return log_debug_errno(r
, "Failed to replace specifiers: %m");
196 if (!dns_service_name_is_valid(name
)) {
197 log_debug("Service instance name '%s' is invalid.", name
);
201 *ret_name
= TAKE_PTR(name
);
206 int dnssd_load(Manager
*manager
) {
207 _cleanup_strv_free_
char **files
= NULL
;
213 if (manager
->mdns_support
!= RESOLVE_SUPPORT_YES
)
216 r
= conf_files_list_strv(&files
, ".dnssd", NULL
, 0, dnssd_service_dirs
);
218 return log_error_errno(r
, "Failed to enumerate .dnssd files: %m");
220 STRV_FOREACH_BACKWARDS(f
, files
) {
221 r
= dnssd_service_load(manager
, *f
);
223 log_warning_errno(r
, "Failed to load '%s': %m", *f
);;
229 int dnssd_update_rrs(DnssdService
*s
) {
230 _cleanup_free_
char *n
= NULL
;
231 _cleanup_free_
char *service_name
= NULL
;
232 _cleanup_free_
char *full_name
= NULL
;
233 DnssdTxtData
*txt_data
;
237 assert(s
->txt_data_items
);
240 s
->ptr_rr
= dns_resource_record_unref(s
->ptr_rr
);
241 s
->srv_rr
= dns_resource_record_unref(s
->srv_rr
);
242 LIST_FOREACH(items
, txt_data
, s
->txt_data_items
)
243 txt_data
->rr
= dns_resource_record_unref(txt_data
->rr
);
245 r
= dnssd_render_instance_name(s
, &n
);
249 r
= dns_name_concat(s
->type
, "local", &service_name
);
252 r
= dns_name_concat(n
, service_name
, &full_name
);
256 LIST_FOREACH(items
, txt_data
, s
->txt_data_items
) {
257 txt_data
->rr
= dns_resource_record_new_full(DNS_CLASS_IN
, DNS_TYPE_TXT
,
262 txt_data
->rr
->ttl
= MDNS_DEFAULT_TTL
;
263 txt_data
->rr
->txt
.items
= dns_txt_item_copy(txt_data
->txt
);
264 if (!txt_data
->rr
->txt
.items
)
268 s
->ptr_rr
= dns_resource_record_new_full(DNS_CLASS_IN
, DNS_TYPE_PTR
,
273 s
->ptr_rr
->ttl
= MDNS_DEFAULT_TTL
;
274 s
->ptr_rr
->ptr
.name
= strdup(full_name
);
275 if (!s
->ptr_rr
->ptr
.name
)
278 s
->srv_rr
= dns_resource_record_new_full(DNS_CLASS_IN
, DNS_TYPE_SRV
,
283 s
->srv_rr
->ttl
= MDNS_DEFAULT_TTL
;
284 s
->srv_rr
->srv
.priority
= s
->priority
;
285 s
->srv_rr
->srv
.weight
= s
->weight
;
286 s
->srv_rr
->srv
.port
= s
->port
;
287 s
->srv_rr
->srv
.name
= strdup(s
->manager
->mdns_hostname
);
288 if (!s
->srv_rr
->srv
.name
)
294 LIST_FOREACH(items
, txt_data
, s
->txt_data_items
)
295 txt_data
->rr
= dns_resource_record_unref(txt_data
->rr
);
296 s
->ptr_rr
= dns_resource_record_unref(s
->ptr_rr
);
297 s
->srv_rr
= dns_resource_record_unref(s
->srv_rr
);
301 int dnssd_txt_item_new_from_string(const char *key
, const char *value
, DnsTxtItem
**ret_item
) {
305 length
= strlen(key
);
308 length
+= strlen(value
) + 1; /* length of value plus '=' */
310 i
= malloc0(offsetof(DnsTxtItem
, data
) + length
+ 1); /* for safety reasons we add an extra NUL byte */
314 memcpy(i
->data
, key
, strlen(key
));
315 if (!isempty(value
)) {
316 memcpy(i
->data
+ strlen(key
), "=", 1);
317 memcpy(i
->data
+ strlen(key
) + 1, value
, strlen(value
));
321 *ret_item
= TAKE_PTR(i
);
326 int dnssd_txt_item_new_from_data(const char *key
, const void *data
, const size_t size
, DnsTxtItem
**ret_item
) {
330 length
= strlen(key
);
333 length
+= size
+ 1; /* size of date plus '=' */
335 i
= malloc0(offsetof(DnsTxtItem
, data
) + length
+ 1); /* for safety reasons we add an extra NUL byte */
339 memcpy(i
->data
, key
, strlen(key
));
341 memcpy(i
->data
+ strlen(key
), "=", 1);
342 memcpy(i
->data
+ strlen(key
) + 1, data
, size
);
346 *ret_item
= TAKE_PTR(i
);
351 void dnssd_signal_conflict(Manager
*manager
, const char *name
) {
356 HASHMAP_FOREACH(s
, manager
->dnssd_services
, i
) {
360 if (dns_name_equal(dns_resource_key_name(s
->srv_rr
->key
), name
)) {
361 _cleanup_free_
char *path
= NULL
;
365 r
= sd_bus_path_encode("/org/freedesktop/resolve1/dnssd", s
->name
, &path
);
367 log_error_errno(r
, "Can't get D-BUS object path: %m");
371 r
= sd_bus_emit_signal(manager
->bus
,
373 "org.freedesktop.resolve1.DnssdService",
377 log_error_errno(r
, "Cannot emit signal: %m");