4 This file is part of avahi.
6 avahi is free software; you can redistribute it and/or modify it
7 under the terms of the GNU Lesser General Public License as
8 published by the Free Software Foundation; either version 2.1 of the
9 License, or (at your option) any later version.
11 avahi is distributed in the hope that it will be useful, but WITHOUT
12 ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
13 or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General
14 Public License for more details.
16 You should have received a copy of the GNU Lesser General Public
17 License along with avahi; if not, write to the Free Software
18 Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307
27 #include <sys/ioctl.h>
28 #include <sys/types.h>
29 #include <sys/socket.h>
30 #include <netinet/in.h>
41 #include <dbus/dbus.h>
43 #include <avahi-common/dbus.h>
44 #include <avahi-common/llist.h>
45 #include <avahi-common/malloc.h>
46 #include <avahi-common/dbus.h>
47 #include <avahi-common/dbus-watch-glue.h>
48 #include <avahi-common/alternative.h>
49 #include <avahi-common/error.h>
50 #include <avahi-common/domain.h>
51 #include <avahi-common/timeval.h>
53 #include <avahi-core/log.h>
54 #include <avahi-core/core.h>
55 #include <avahi-core/lookup.h>
56 #include <avahi-core/publish.h>
58 #include "dbus-protocol.h"
59 #include "dbus-util.h"
60 #include "dbus-internal.h"
63 /* #define VALGRIND_WORKAROUND 1 */
65 #define RECONNECT_MSEC 3000
67 Server *server = NULL;
69 static int disable_user_service_publishing = 0;
71 static int dbus_connect(void);
72 static void dbus_disconnect(void);
74 static void client_free(Client *c) {
79 while (c->entry_groups)
80 avahi_dbus_entry_group_free(c->entry_groups);
82 while (c->sync_host_name_resolvers)
83 avahi_dbus_sync_host_name_resolver_free(c->sync_host_name_resolvers);
85 while (c->async_host_name_resolvers)
86 avahi_dbus_async_host_name_resolver_free(c->async_host_name_resolvers);
88 while (c->sync_address_resolvers)
89 avahi_dbus_sync_address_resolver_free(c->sync_address_resolvers);
91 while (c->async_address_resolvers)
92 avahi_dbus_async_address_resolver_free(c->async_address_resolvers);
94 while (c->domain_browsers)
95 avahi_dbus_domain_browser_free(c->domain_browsers);
97 while (c->service_type_browsers)
98 avahi_dbus_service_type_browser_free(c->service_type_browsers);
100 while (c->service_browsers)
101 avahi_dbus_service_browser_free(c->service_browsers);
103 while (c->sync_service_resolvers)
104 avahi_dbus_sync_service_resolver_free(c->sync_service_resolvers);
106 while (c->async_service_resolvers)
107 avahi_dbus_async_service_resolver_free(c->async_service_resolvers);
109 while (c->record_browsers)
110 avahi_dbus_record_browser_free(c->record_browsers);
112 assert(c->n_objects == 0);
115 AVAHI_LLIST_REMOVE(Client, clients, server->clients, c);
118 server->n_clients --;
119 assert(server->n_clients >= 0);
122 static Client *client_get(const char *name, int create) {
128 for (client = server->clients; client; client = client->clients_next)
129 if (!strcmp(name, client->name))
135 if (server->n_clients >= CLIENTS_MAX)
138 /* If not existant yet, create a new entry */
139 client = avahi_new(Client, 1);
140 client->id = server->current_id++;
141 client->name = avahi_strdup(name);
142 client->current_id = 0;
143 client->n_objects = 0;
145 AVAHI_LLIST_HEAD_INIT(EntryGroupInfo, client->entry_groups);
146 AVAHI_LLIST_HEAD_INIT(SyncHostNameResolverInfo, client->sync_host_name_resolvers);
147 AVAHI_LLIST_HEAD_INIT(AsyncHostNameResolverInfo, client->async_host_name_resolvers);
148 AVAHI_LLIST_HEAD_INIT(SyncAddressResolverInfo, client->sync_address_resolvers);
149 AVAHI_LLIST_HEAD_INIT(AsyncAddressResolverInfo, client->async_address_resolvers);
150 AVAHI_LLIST_HEAD_INIT(DomainBrowserInfo, client->domain_browsers);
151 AVAHI_LLIST_HEAD_INIT(ServiceTypeBrowserInfo, client->service_type_browsers);
152 AVAHI_LLIST_HEAD_INIT(ServiceBrowserInfo, client->service_browsers);
153 AVAHI_LLIST_HEAD_INIT(SyncServiceResolverInfo, client->sync_service_resolvers);
154 AVAHI_LLIST_HEAD_INIT(AsyncServiceResolverInfo, client->async_service_resolvers);
155 AVAHI_LLIST_HEAD_INIT(RecordBrowserInfo, client->record_browsers);
157 AVAHI_LLIST_PREPEND(Client, clients, server->clients, client);
160 assert(server->n_clients > 0);
165 static void reconnect_callback(AvahiTimeout *t, AVAHI_GCC_UNUSED void *userdata) {
166 assert(!server->bus);
168 if (dbus_connect() < 0) {
170 avahi_log_debug(__FILE__": Connection failed, retrying in %ims...", RECONNECT_MSEC);
171 avahi_elapse_time(&tv, RECONNECT_MSEC, 0);
172 server->poll_api->timeout_update(t, &tv);
174 avahi_log_debug(__FILE__": Successfully reconnected.");
175 server->poll_api->timeout_update(t, NULL);
179 static DBusHandlerResult msg_signal_filter_impl(AVAHI_GCC_UNUSED DBusConnection *c, DBusMessage *m, AVAHI_GCC_UNUSED void *userdata) {
182 dbus_error_init(&error);
184 /* avahi_log_debug(__FILE__": interface=%s, path=%s, member=%s", */
185 /* dbus_message_get_interface(m), */
186 /* dbus_message_get_path(m), */
187 /* dbus_message_get_member(m)); */
189 if (dbus_message_is_signal(m, DBUS_INTERFACE_LOCAL, "Disconnected")) {
192 if (server->reconnect) {
193 avahi_log_warn("Disconnnected from D-BUS, trying to reconnect in %ims...", RECONNECT_MSEC);
197 avahi_elapse_time(&tv, RECONNECT_MSEC, 0);
199 if (server->reconnect_timeout)
200 server->poll_api->timeout_update(server->reconnect_timeout, &tv);
202 server->reconnect_timeout = server->poll_api->timeout_new(server->poll_api, &tv, reconnect_callback, NULL);
204 avahi_log_warn("Disconnnected from D-BUS, exiting.");
208 return DBUS_HANDLER_RESULT_HANDLED;
210 } else if (dbus_message_is_signal(m, DBUS_INTERFACE_DBUS, "NameAcquired")) {
213 if (!dbus_message_get_args(m, &error, DBUS_TYPE_STRING, &name, DBUS_TYPE_INVALID)) {
214 avahi_log_warn("Error parsing NameAcquired message");
218 /* avahi_log_info(__FILE__": name acquired (%s)", name); */
219 return DBUS_HANDLER_RESULT_HANDLED;
221 } else if (dbus_message_is_signal(m, DBUS_INTERFACE_DBUS, "NameOwnerChanged")) {
222 char *name, *old, *new;
224 if (!dbus_message_get_args(m, &error, DBUS_TYPE_STRING, &name, DBUS_TYPE_STRING, &old, DBUS_TYPE_STRING, &new, DBUS_TYPE_INVALID)) {
225 avahi_log_warn("Error parsing NameOwnerChanged message");
232 if ((client = client_get(name, FALSE))) {
233 avahi_log_debug(__FILE__": client %s vanished.", name);
240 if (dbus_error_is_set(&error))
241 dbus_error_free(&error);
243 return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
246 static DBusHandlerResult msg_server_impl(DBusConnection *c, DBusMessage *m, AVAHI_GCC_UNUSED void *userdata) {
249 dbus_error_init(&error);
251 avahi_log_debug(__FILE__": interface=%s, path=%s, member=%s",
252 dbus_message_get_interface(m),
253 dbus_message_get_path(m),
254 dbus_message_get_member(m));
256 if (dbus_message_is_method_call(m, DBUS_INTERFACE_INTROSPECTABLE, "Introspect"))
257 return avahi_dbus_handle_introspect(c, m, "Server.introspect");
259 else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "GetHostName")) {
261 if (!dbus_message_get_args(m, &error, DBUS_TYPE_INVALID)) {
262 avahi_log_warn("Error parsing Server::GetHostName message");
266 return avahi_dbus_respond_string(c, m, avahi_server_get_host_name(avahi_server));
268 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "GetDomainName")) {
270 if (!dbus_message_get_args(m, &error, DBUS_TYPE_INVALID)) {
271 avahi_log_warn("Error parsing Server::GetDomainName message");
275 return avahi_dbus_respond_string(c, m, avahi_server_get_domain_name(avahi_server));
277 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "GetHostNameFqdn")) {
279 if (!(dbus_message_get_args(m, &error, DBUS_TYPE_INVALID))) {
280 avahi_log_warn("Error parsing Server::GetHostNameFqdn message");
284 return avahi_dbus_respond_string(c, m, avahi_server_get_host_name_fqdn(avahi_server));
286 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "IsNSSSupportAvailable")) {
287 if (!(dbus_message_get_args(m, &error, DBUS_TYPE_INVALID))) {
288 avahi_log_warn("Error parsing Server::IsNSSSupportAvailable message");
292 return avahi_dbus_respond_boolean(c, m, nss_support);
294 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "GetVersionString")) {
296 if (!(dbus_message_get_args(m, &error, DBUS_TYPE_INVALID))) {
297 avahi_log_warn("Error parsing Server::GetVersionString message");
301 return avahi_dbus_respond_string(c, m, PACKAGE_STRING);
303 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "GetAPIVersion")) {
305 if (!(dbus_message_get_args(m, &error, DBUS_TYPE_INVALID))) {
306 avahi_log_warn("Error parsing Server::GetAPIVersion message");
310 return avahi_dbus_respond_uint32(c, m, AVAHI_DBUS_API_VERSION);
312 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "GetState")) {
313 AvahiServerState state;
315 if (!(dbus_message_get_args(m, &error, DBUS_TYPE_INVALID))) {
316 avahi_log_warn("Error parsing Server::GetState message");
320 state = avahi_server_get_state(avahi_server);
321 return avahi_dbus_respond_int32(c, m, (int32_t) state);
323 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "GetLocalServiceCookie")) {
325 if (!(dbus_message_get_args(m, &error, DBUS_TYPE_INVALID))) {
326 avahi_log_warn("Error parsing Server::GetLocalServiceCookie message");
330 return avahi_dbus_respond_uint32(c, m, avahi_server_get_local_service_cookie(avahi_server));
332 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "GetNetworkInterfaceNameByIndex")) {
335 char name[IF_NAMESIZE];
338 if (!(dbus_message_get_args(m, &error, DBUS_TYPE_INT32, &idx, DBUS_TYPE_INVALID))) {
339 avahi_log_warn("Error parsing Server::GetNetworkInterfaceNameByIndex message");
343 #ifdef VALGRIND_WORKAROUND
344 return respond_string(c, m, "blah");
347 if ((fd = socket(AF_INET, SOCK_DGRAM, 0)) < 0)
348 if ((fd = socket(AF_INET6, SOCK_DGRAM, 0)) < 0) {
350 snprintf(txt, sizeof(txt), "OS Error: %s", strerror(errno));
351 return avahi_dbus_respond_error(c, m, AVAHI_ERR_OS, txt);
354 if ((!if_indextoname(idx, name))) {
356 snprintf(txt, sizeof(txt), "OS Error: %s", strerror(errno));
358 return avahi_dbus_respond_error(c, m, AVAHI_ERR_OS, txt);
363 return avahi_dbus_respond_string(c, m, name);
366 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "GetNetworkInterfaceIndexByName")) {
371 if (!(dbus_message_get_args(m, &error, DBUS_TYPE_STRING, &n, DBUS_TYPE_INVALID)) || !n) {
372 avahi_log_warn("Error parsing Server::GetNetworkInterfaceIndexByName message");
376 #ifdef VALGRIND_WORKAROUND
377 return respond_int32(c, m, 1);
379 if ((fd = socket(AF_INET, SOCK_DGRAM, 0)) < 0)
380 if ((fd = socket(AF_INET6, SOCK_DGRAM, 0)) < 0) {
382 snprintf(txt, sizeof(txt), "OS Error: %s", strerror(errno));
383 return avahi_dbus_respond_error(c, m, AVAHI_ERR_OS, txt);
386 if (!(idx = if_nametoindex(n))) {
388 snprintf(txt, sizeof(txt), "OS Error: %s", strerror(errno));
390 return avahi_dbus_respond_error(c, m, AVAHI_ERR_OS, txt);
395 return avahi_dbus_respond_int32(c, m, idx);
398 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "GetAlternativeHostName")) {
401 if (!(dbus_message_get_args(m, &error, DBUS_TYPE_STRING, &n, DBUS_TYPE_INVALID)) || !n) {
402 avahi_log_warn("Error parsing Server::GetAlternativeHostName message");
406 t = avahi_alternative_host_name(n);
407 avahi_dbus_respond_string(c, m, t);
410 return DBUS_HANDLER_RESULT_HANDLED;
412 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "GetAlternativeServiceName")) {
415 if (!(dbus_message_get_args(m, &error, DBUS_TYPE_STRING, &n, DBUS_TYPE_INVALID)) || !n) {
416 avahi_log_warn("Error parsing Server::GetAlternativeServiceName message");
420 t = avahi_alternative_service_name(n);
421 avahi_dbus_respond_string(c, m, t);
424 return DBUS_HANDLER_RESULT_HANDLED;
426 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "EntryGroupNew")) {
429 static const DBusObjectPathVTable vtable = {
431 avahi_dbus_msg_entry_group_impl,
438 if (!dbus_message_get_args(m, &error, DBUS_TYPE_INVALID)) {
439 avahi_log_warn("Error parsing Server::EntryGroupNew message");
443 if (disable_user_service_publishing)
444 return avahi_dbus_respond_error(c, m, AVAHI_ERR_NOT_PERMITTED, NULL);
446 if (!(client = client_get(dbus_message_get_sender(m), TRUE))) {
447 avahi_log_warn("Too many clients, client request failed.");
448 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_CLIENTS, NULL);
451 if (client->n_objects >= OBJECTS_PER_CLIENT_MAX) {
452 avahi_log_warn("Too many objects for client '%s', client request failed.", client->name);
453 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_OBJECTS, NULL);
456 i = avahi_new(EntryGroupInfo, 1);
457 i->id = ++client->current_id;
461 AVAHI_LLIST_PREPEND(EntryGroupInfo, entry_groups, client->entry_groups, i);
464 if (!(i->entry_group = avahi_s_entry_group_new(avahi_server, avahi_dbus_entry_group_callback, i))) {
465 avahi_dbus_entry_group_free(i);
466 return avahi_dbus_respond_error(c, m, avahi_server_errno(avahi_server), NULL);
469 i->path = avahi_strdup_printf("/Client%u/EntryGroup%u", client->id, i->id);
470 dbus_connection_register_object_path(c, i->path, &vtable, i);
471 return avahi_dbus_respond_path(c, m, i->path);
473 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "ResolveHostName")) {
475 int32_t interface, protocol, aprotocol;
478 SyncHostNameResolverInfo *i;
480 if (!dbus_message_get_args(
482 DBUS_TYPE_INT32, &interface,
483 DBUS_TYPE_INT32, &protocol,
484 DBUS_TYPE_STRING, &name,
485 DBUS_TYPE_INT32, &aprotocol,
486 DBUS_TYPE_UINT32, &flags,
487 DBUS_TYPE_INVALID) || !name) {
488 avahi_log_warn("Error parsing Server::ResolveHostName message");
492 if (!(client = client_get(dbus_message_get_sender(m), TRUE))) {
493 avahi_log_warn("Too many clients, client request failed.");
494 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_CLIENTS, NULL);
497 if (client->n_objects >= OBJECTS_PER_CLIENT_MAX) {
498 avahi_log_warn("Too many objects for client '%s', client request failed.", client->name);
499 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_OBJECTS, NULL);
502 i = avahi_new(SyncHostNameResolverInfo, 1);
504 i->message = dbus_message_ref(m);
505 AVAHI_LLIST_PREPEND(SyncHostNameResolverInfo, sync_host_name_resolvers, client->sync_host_name_resolvers, i);
508 if (!(i->host_name_resolver = avahi_s_host_name_resolver_new(avahi_server, (AvahiIfIndex) interface, (AvahiProtocol) protocol, name, (AvahiProtocol) aprotocol, (AvahiLookupFlags) flags, avahi_dbus_sync_host_name_resolver_callback, i))) {
509 avahi_dbus_sync_host_name_resolver_free(i);
510 return avahi_dbus_respond_error(c, m, avahi_server_errno(avahi_server), NULL);
513 return DBUS_HANDLER_RESULT_HANDLED;
515 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "ResolveAddress")) {
517 int32_t interface, protocol;
520 SyncAddressResolverInfo *i;
523 if (!dbus_message_get_args(
525 DBUS_TYPE_INT32, &interface,
526 DBUS_TYPE_INT32, &protocol,
527 DBUS_TYPE_STRING, &address,
528 DBUS_TYPE_UINT32, &flags,
529 DBUS_TYPE_INVALID) || !address) {
530 avahi_log_warn("Error parsing Server::ResolveAddress message");
534 if (!avahi_address_parse(address, AVAHI_PROTO_UNSPEC, &a))
535 return avahi_dbus_respond_error(c, m, AVAHI_ERR_INVALID_ADDRESS, NULL);
537 if (!(client = client_get(dbus_message_get_sender(m), TRUE))) {
538 avahi_log_warn("Too many clients, client request failed.");
539 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_CLIENTS, NULL);
542 if (client->n_objects >= OBJECTS_PER_CLIENT_MAX) {
543 avahi_log_warn("Too many objects for client '%s', client request failed.", client->name);
544 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_OBJECTS, NULL);
547 i = avahi_new(SyncAddressResolverInfo, 1);
549 i->message = dbus_message_ref(m);
550 AVAHI_LLIST_PREPEND(SyncAddressResolverInfo, sync_address_resolvers, client->sync_address_resolvers, i);
553 if (!(i->address_resolver = avahi_s_address_resolver_new(avahi_server, (AvahiIfIndex) interface, (AvahiProtocol) protocol, &a, (AvahiLookupFlags) flags, avahi_dbus_sync_address_resolver_callback, i))) {
554 avahi_dbus_sync_address_resolver_free(i);
555 return avahi_dbus_respond_error(c, m, avahi_server_errno(avahi_server), NULL);
558 return DBUS_HANDLER_RESULT_HANDLED;
560 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "DomainBrowserNew")) {
562 DomainBrowserInfo *i;
563 static const DBusObjectPathVTable vtable = {
565 avahi_dbus_msg_domain_browser_impl,
571 int32_t interface, protocol, type;
575 if (!dbus_message_get_args(
577 DBUS_TYPE_INT32, &interface,
578 DBUS_TYPE_INT32, &protocol,
579 DBUS_TYPE_STRING, &domain,
580 DBUS_TYPE_INT32, &type,
581 DBUS_TYPE_UINT32, &flags,
582 DBUS_TYPE_INVALID) || type < 0 || type >= AVAHI_DOMAIN_BROWSER_MAX) {
583 avahi_log_warn("Error parsing Server::DomainBrowserNew message");
587 if (!(client = client_get(dbus_message_get_sender(m), TRUE))) {
588 avahi_log_warn("Too many clients, client request failed.");
589 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_CLIENTS, NULL);
592 if (client->n_objects >= OBJECTS_PER_CLIENT_MAX) {
593 avahi_log_warn("Too many objects for client '%s', client request failed.", client->name);
594 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_OBJECTS, NULL);
600 i = avahi_new(DomainBrowserInfo, 1);
601 i->id = ++client->current_id;
604 AVAHI_LLIST_PREPEND(DomainBrowserInfo, domain_browsers, client->domain_browsers, i);
607 if (!(i->domain_browser = avahi_s_domain_browser_new(avahi_server, (AvahiIfIndex) interface, (AvahiProtocol) protocol, domain, (AvahiDomainBrowserType) type, (AvahiLookupFlags) flags, avahi_dbus_domain_browser_callback, i))) {
608 avahi_dbus_domain_browser_free(i);
609 return avahi_dbus_respond_error(c, m, avahi_server_errno(avahi_server), NULL);
612 i->path = avahi_strdup_printf("/Client%u/DomainBrowser%u", client->id, i->id);
613 dbus_connection_register_object_path(c, i->path, &vtable, i);
614 return avahi_dbus_respond_path(c, m, i->path);
616 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "ServiceTypeBrowserNew")) {
618 ServiceTypeBrowserInfo *i;
619 static const DBusObjectPathVTable vtable = {
621 avahi_dbus_msg_service_type_browser_impl,
627 int32_t interface, protocol;
631 if (!dbus_message_get_args(
633 DBUS_TYPE_INT32, &interface,
634 DBUS_TYPE_INT32, &protocol,
635 DBUS_TYPE_STRING, &domain,
636 DBUS_TYPE_UINT32, &flags,
637 DBUS_TYPE_INVALID)) {
638 avahi_log_warn("Error parsing Server::ServiceTypeBrowserNew message");
642 if (!(client = client_get(dbus_message_get_sender(m), TRUE))) {
643 avahi_log_warn("Too many clients, client request failed.");
644 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_CLIENTS, NULL);
647 if (client->n_objects >= OBJECTS_PER_CLIENT_MAX) {
648 avahi_log_warn("Too many objects for client '%s', client request failed.", client->name);
649 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_OBJECTS, NULL);
655 i = avahi_new(ServiceTypeBrowserInfo, 1);
656 i->id = ++client->current_id;
659 AVAHI_LLIST_PREPEND(ServiceTypeBrowserInfo, service_type_browsers, client->service_type_browsers, i);
662 if (!(i->service_type_browser = avahi_s_service_type_browser_new(avahi_server, (AvahiIfIndex) interface, (AvahiProtocol) protocol, domain, (AvahiLookupFlags) flags, avahi_dbus_service_type_browser_callback, i))) {
663 avahi_dbus_service_type_browser_free(i);
664 return avahi_dbus_respond_error(c, m, avahi_server_errno(avahi_server), NULL);
667 i->path = avahi_strdup_printf("/Client%u/ServiceTypeBrowser%u", client->id, i->id);
668 dbus_connection_register_object_path(c, i->path, &vtable, i);
669 return avahi_dbus_respond_path(c, m, i->path);
671 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "ServiceBrowserNew")) {
673 ServiceBrowserInfo *i;
674 static const DBusObjectPathVTable vtable = {
676 avahi_dbus_msg_service_browser_impl,
682 int32_t interface, protocol;
686 if (!dbus_message_get_args(
688 DBUS_TYPE_INT32, &interface,
689 DBUS_TYPE_INT32, &protocol,
690 DBUS_TYPE_STRING, &type,
691 DBUS_TYPE_STRING, &domain,
692 DBUS_TYPE_UINT32, &flags,
693 DBUS_TYPE_INVALID) || !type) {
694 avahi_log_warn("Error parsing Server::ServiceBrowserNew message");
698 if (!(client = client_get(dbus_message_get_sender(m), TRUE))) {
699 avahi_log_warn("Too many clients, client request failed.");
700 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_CLIENTS, NULL);
703 if (client->n_objects >= OBJECTS_PER_CLIENT_MAX) {
704 avahi_log_warn("Too many objects for client '%s', client request failed.", client->name);
705 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_OBJECTS, NULL);
711 i = avahi_new(ServiceBrowserInfo, 1);
712 i->id = ++client->current_id;
715 AVAHI_LLIST_PREPEND(ServiceBrowserInfo, service_browsers, client->service_browsers, i);
718 if (!(i->service_browser = avahi_s_service_browser_new(avahi_server, (AvahiIfIndex) interface, (AvahiProtocol) protocol, type, domain, (AvahiLookupFlags) flags, avahi_dbus_service_browser_callback, i))) {
719 avahi_dbus_service_browser_free(i);
720 return avahi_dbus_respond_error(c, m, avahi_server_errno(avahi_server), NULL);
723 i->path = avahi_strdup_printf("/Client%u/ServiceBrowser%u", client->id, i->id);
724 dbus_connection_register_object_path(c, i->path, &vtable, i);
725 return avahi_dbus_respond_path(c, m, i->path);
727 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "ResolveService")) {
729 int32_t interface, protocol, aprotocol;
731 char *name, *type, *domain;
732 SyncServiceResolverInfo *i;
734 if (!dbus_message_get_args(
736 DBUS_TYPE_INT32, &interface,
737 DBUS_TYPE_INT32, &protocol,
738 DBUS_TYPE_STRING, &name,
739 DBUS_TYPE_STRING, &type,
740 DBUS_TYPE_STRING, &domain,
741 DBUS_TYPE_INT32, &aprotocol,
742 DBUS_TYPE_UINT32, &flags,
743 DBUS_TYPE_INVALID) || !type) {
744 avahi_log_warn("Error parsing Server::ResolveService message");
748 if (!(client = client_get(dbus_message_get_sender(m), TRUE))) {
749 avahi_log_warn("Too many clients, client request failed.");
750 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_CLIENTS, NULL);
753 if (client->n_objects >= OBJECTS_PER_CLIENT_MAX) {
754 avahi_log_warn("Too many objects for client '%s', client request failed.", client->name);
755 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_OBJECTS, NULL);
764 i = avahi_new(SyncServiceResolverInfo, 1);
766 i->message = dbus_message_ref(m);
767 AVAHI_LLIST_PREPEND(SyncServiceResolverInfo, sync_service_resolvers, client->sync_service_resolvers, i);
770 if (!(i->service_resolver = avahi_s_service_resolver_new(avahi_server, (AvahiIfIndex) interface, (AvahiProtocol) protocol, name, type, domain, (AvahiProtocol) aprotocol, (AvahiLookupFlags) flags, avahi_dbus_sync_service_resolver_callback, i))) {
771 avahi_dbus_sync_service_resolver_free(i);
772 return avahi_dbus_respond_error(c, m, avahi_server_errno(avahi_server), NULL);
775 return DBUS_HANDLER_RESULT_HANDLED;
777 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "ServiceResolverNew")) {
779 int32_t interface, protocol, aprotocol;
781 char *name, *type, *domain;
782 AsyncServiceResolverInfo *i;
783 static const DBusObjectPathVTable vtable = {
785 avahi_dbus_msg_async_service_resolver_impl,
792 if (!dbus_message_get_args(
794 DBUS_TYPE_INT32, &interface,
795 DBUS_TYPE_INT32, &protocol,
796 DBUS_TYPE_STRING, &name,
797 DBUS_TYPE_STRING, &type,
798 DBUS_TYPE_STRING, &domain,
799 DBUS_TYPE_INT32, &aprotocol,
800 DBUS_TYPE_UINT32, &flags,
801 DBUS_TYPE_INVALID) || !type) {
802 avahi_log_warn("Error parsing Server::ServiceResolverNew message");
806 if (!(client = client_get(dbus_message_get_sender(m), TRUE))) {
807 avahi_log_warn(__FILE__": Too many clients, client request failed.");
808 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_CLIENTS, NULL);
811 if (client->n_objects >= OBJECTS_PER_CLIENT_MAX) {
812 avahi_log_warn(__FILE__": Too many objects for client '%s', client request failed.", client->name);
813 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_OBJECTS, NULL);
822 i = avahi_new(AsyncServiceResolverInfo, 1);
823 i->id = ++client->current_id;
826 AVAHI_LLIST_PREPEND(AsyncServiceResolverInfo, async_service_resolvers, client->async_service_resolvers, i);
829 if (!(i->service_resolver = avahi_s_service_resolver_new(avahi_server, (AvahiIfIndex) interface, (AvahiProtocol) protocol, name, type, domain, (AvahiProtocol) aprotocol, (AvahiLookupFlags) flags, avahi_dbus_async_service_resolver_callback, i))) {
830 avahi_dbus_async_service_resolver_free(i);
831 return avahi_dbus_respond_error(c, m, avahi_server_errno(avahi_server), NULL);
834 /* avahi_log_debug(__FILE__": [%s], new service resolver for <%s.%s.%s>", i->path, name, type, domain); */
836 i->path = avahi_strdup_printf("/Client%u/ServiceResolver%u", client->id, i->id);
837 dbus_connection_register_object_path(c, i->path, &vtable, i);
838 return avahi_dbus_respond_path(c, m, i->path);
840 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "HostNameResolverNew")) {
842 int32_t interface, protocol, aprotocol;
845 AsyncHostNameResolverInfo *i;
846 static const DBusObjectPathVTable vtable = {
848 avahi_dbus_msg_async_host_name_resolver_impl,
855 if (!dbus_message_get_args(
857 DBUS_TYPE_INT32, &interface,
858 DBUS_TYPE_INT32, &protocol,
859 DBUS_TYPE_STRING, &name,
860 DBUS_TYPE_INT32, &aprotocol,
861 DBUS_TYPE_UINT32, &flags,
862 DBUS_TYPE_INVALID) || !name) {
863 avahi_log_warn("Error parsing Server::HostNameResolverNew message");
867 if (!(client = client_get(dbus_message_get_sender(m), TRUE))) {
868 avahi_log_warn(__FILE__": Too many clients, client request failed.");
869 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_CLIENTS, NULL);
872 if (client->n_objects >= OBJECTS_PER_CLIENT_MAX) {
873 avahi_log_warn(__FILE__": Too many objects for client '%s', client request failed.", client->name);
874 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_OBJECTS, NULL);
877 i = avahi_new(AsyncHostNameResolverInfo, 1);
878 i->id = ++client->current_id;
881 AVAHI_LLIST_PREPEND(AsyncHostNameResolverInfo, async_host_name_resolvers, client->async_host_name_resolvers, i);
884 if (!(i->host_name_resolver = avahi_s_host_name_resolver_new(avahi_server, (AvahiIfIndex) interface, (AvahiProtocol) protocol, name, aprotocol, (AvahiLookupFlags) flags, avahi_dbus_async_host_name_resolver_callback, i))) {
885 avahi_dbus_async_host_name_resolver_free(i);
886 return avahi_dbus_respond_error(c, m, avahi_server_errno(avahi_server), NULL);
889 i->path = avahi_strdup_printf("/Client%u/HostNameResolver%u", client->id, i->id);
890 dbus_connection_register_object_path(c, i->path, &vtable, i);
891 return avahi_dbus_respond_path(c, m, i->path);
893 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "AddressResolverNew")) {
895 int32_t interface, protocol;
898 AsyncAddressResolverInfo *i;
900 static const DBusObjectPathVTable vtable = {
902 avahi_dbus_msg_async_address_resolver_impl,
909 if (!dbus_message_get_args(
911 DBUS_TYPE_INT32, &interface,
912 DBUS_TYPE_INT32, &protocol,
913 DBUS_TYPE_STRING, &address,
914 DBUS_TYPE_UINT32, &flags,
915 DBUS_TYPE_INVALID) || !address) {
916 avahi_log_warn("Error parsing Server::AddressResolverNew message");
920 if (!avahi_address_parse(address, AVAHI_PROTO_UNSPEC, &a))
921 return avahi_dbus_respond_error(c, m, AVAHI_ERR_INVALID_ADDRESS, NULL);
923 if (!(client = client_get(dbus_message_get_sender(m), TRUE))) {
924 avahi_log_warn(__FILE__": Too many clients, client request failed.");
925 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_CLIENTS, NULL);
928 if (client->n_objects >= OBJECTS_PER_CLIENT_MAX) {
929 avahi_log_warn(__FILE__": Too many objects for client '%s', client request failed.", client->name);
930 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_OBJECTS, NULL);
933 i = avahi_new(AsyncAddressResolverInfo, 1);
934 i->id = ++client->current_id;
937 AVAHI_LLIST_PREPEND(AsyncAddressResolverInfo, async_address_resolvers, client->async_address_resolvers, i);
940 if (!(i->address_resolver = avahi_s_address_resolver_new(avahi_server, (AvahiIfIndex) interface, (AvahiProtocol) protocol, &a, (AvahiLookupFlags) flags, avahi_dbus_async_address_resolver_callback, i))) {
941 avahi_dbus_async_address_resolver_free(i);
942 return avahi_dbus_respond_error(c, m, avahi_server_errno(avahi_server), NULL);
945 i->path = avahi_strdup_printf("/Client%u/AddressResolver%u", client->id, i->id);
946 dbus_connection_register_object_path(c, i->path, &vtable, i);
947 return avahi_dbus_respond_path(c, m, i->path);
949 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "RecordBrowserNew")) {
951 RecordBrowserInfo *i;
952 static const DBusObjectPathVTable vtable = {
954 avahi_dbus_msg_record_browser_impl,
960 int32_t interface, protocol;
963 uint16_t type, clazz;
966 if (!dbus_message_get_args(
968 DBUS_TYPE_INT32, &interface,
969 DBUS_TYPE_INT32, &protocol,
970 DBUS_TYPE_STRING, &name,
971 DBUS_TYPE_UINT16, &clazz,
972 DBUS_TYPE_UINT16, &type,
973 DBUS_TYPE_UINT32, &flags,
974 DBUS_TYPE_INVALID) || !name) {
975 avahi_log_warn("Error parsing Server::RecordBrowserNew message");
979 if (!avahi_is_valid_domain_name(name))
980 return avahi_dbus_respond_error(c, m, AVAHI_ERR_INVALID_DOMAIN_NAME, NULL);
982 if (!(client = client_get(dbus_message_get_sender(m), TRUE))) {
983 avahi_log_warn("Too many clients, client request failed.");
984 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_CLIENTS, NULL);
987 if (client->n_objects >= OBJECTS_PER_CLIENT_MAX) {
988 avahi_log_warn("Too many objects for client '%s', client request failed.", client->name);
989 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_OBJECTS, NULL);
992 i = avahi_new(RecordBrowserInfo, 1);
993 i->id = ++client->current_id;
996 AVAHI_LLIST_PREPEND(RecordBrowserInfo, record_browsers, client->record_browsers, i);
999 key = avahi_key_new(name, clazz, type);
1002 if (!(i->record_browser = avahi_s_record_browser_new(avahi_server, (AvahiIfIndex) interface, (AvahiProtocol) protocol, key, (AvahiLookupFlags) flags, avahi_dbus_record_browser_callback, i))) {
1003 avahi_key_unref(key);
1004 avahi_dbus_record_browser_free(i);
1005 return avahi_dbus_respond_error(c, m, avahi_server_errno(avahi_server), NULL);
1008 avahi_key_unref(key);
1010 i->path = avahi_strdup_printf("/Client%u/RecordBrowser%u", client->id, i->id);
1011 dbus_connection_register_object_path(c, i->path, &vtable, i);
1012 return avahi_dbus_respond_path(c, m, i->path);
1015 avahi_log_warn("Missed message %s::%s()", dbus_message_get_interface(m), dbus_message_get_member(m));
1018 if (dbus_error_is_set(&error))
1019 dbus_error_free(&error);
1021 return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
1024 void dbus_protocol_server_state_changed(AvahiServerState state) {
1029 if (!server || !server->bus)
1032 m = dbus_message_new_signal(AVAHI_DBUS_PATH_SERVER, AVAHI_DBUS_INTERFACE_SERVER, "StateChanged");
1033 t = (int32_t) state;
1035 if (state == AVAHI_SERVER_COLLISION)
1036 e = AVAHI_DBUS_ERR_COLLISION;
1037 else if (state == AVAHI_SERVER_FAILURE)
1038 e = avahi_error_number_to_dbus(avahi_server_errno(avahi_server));
1040 e = AVAHI_DBUS_ERR_OK;
1042 dbus_message_append_args(m, DBUS_TYPE_INT32, &t, DBUS_TYPE_STRING, &e, DBUS_TYPE_INVALID);
1043 dbus_connection_send(server->bus, m, NULL);
1044 dbus_message_unref(m);
1047 static int dbus_connect(void) {
1050 static const DBusObjectPathVTable server_vtable = {
1060 assert(!server->bus);
1062 dbus_error_init(&error);
1064 if (!(server->bus = dbus_bus_get(DBUS_BUS_SYSTEM, &error))) {
1065 assert(dbus_error_is_set(&error));
1066 avahi_log_error("dbus_bus_get(): %s", error.message);
1069 if (avahi_dbus_connection_glue(server->bus, server->poll_api) < 0) {
1070 avahi_log_error("avahi_dbus_connection_glue() failed");
1074 dbus_connection_set_exit_on_disconnect(server->bus, FALSE);
1076 if (dbus_bus_request_name(
1079 #if (DBUS_VERSION_MAJOR == 0) && (DBUS_VERSION_MINOR >= 60)
1080 DBUS_NAME_FLAG_DO_NOT_QUEUE,
1082 DBUS_NAME_FLAG_PROHIBIT_REPLACEMENT,
1084 &error) != DBUS_REQUEST_NAME_REPLY_PRIMARY_OWNER) {
1085 if (dbus_error_is_set(&error)) {
1086 avahi_log_error("dbus_bus_request_name(): %s", error.message);
1090 avahi_log_error("Failed to acquire DBUS name '"AVAHI_DBUS_NAME"'");
1094 if (!(dbus_connection_add_filter(server->bus, msg_signal_filter_impl, (void*) server->poll_api, NULL))) {
1095 avahi_log_error("dbus_connection_add_filter() failed");
1099 dbus_bus_add_match(server->bus, "type='signal',""interface='" DBUS_INTERFACE_DBUS "'", &error);
1101 if (dbus_error_is_set(&error)) {
1102 avahi_log_error("dbus_bus_add_match(): %s", error.message);
1106 if (!(dbus_connection_register_object_path(server->bus, AVAHI_DBUS_PATH_SERVER, &server_vtable, NULL))) {
1107 avahi_log_error("dbus_connection_register_object_path() failed");
1114 if (dbus_error_is_set(&error))
1115 dbus_error_free(&error);
1118 #if (DBUS_VERSION_MAJOR == 0) && (DBUS_VERSION_MINOR >= 62)
1119 dbus_connection_close(server->bus);
1121 dbus_connection_disconnect(server->bus);
1123 dbus_connection_unref(server->bus);
1130 static void dbus_disconnect(void) {
1133 while (server->clients)
1134 client_free(server->clients);
1136 assert(server->n_clients == 0);
1139 #if (DBUS_VERSION_MAJOR == 0) && (DBUS_VERSION_MINOR >= 62)
1140 dbus_connection_close(server->bus);
1142 dbus_connection_disconnect(server->bus);
1144 dbus_connection_unref(server->bus);
1149 int dbus_protocol_setup(const AvahiPoll *poll_api, int _disable_user_service_publishing, int force) {
1151 disable_user_service_publishing = _disable_user_service_publishing;
1153 server = avahi_new(Server, 1);
1154 AVAHI_LLIST_HEAD_INIT(Clients, server->clients);
1155 server->current_id = 0;
1156 server->n_clients = 0;
1158 server->poll_api = poll_api;
1159 server->reconnect_timeout = NULL;
1160 server->reconnect = force;
1162 if (dbus_connect() < 0) {
1168 avahi_log_warn("WARNING: Failed to contact D-BUS daemon, retrying in %ims.", RECONNECT_MSEC);
1170 avahi_elapse_time(&tv, RECONNECT_MSEC, 0);
1171 server->reconnect_timeout = server->poll_api->timeout_new(server->poll_api, &tv, reconnect_callback, NULL);
1178 #if (DBUS_VERSION_MAJOR == 0) && (DBUS_VERSION_MINOR >= 62)
1179 dbus_connection_close(server->bus);
1181 dbus_connection_disconnect(server->bus);
1183 dbus_connection_unref(server->bus);
1191 void dbus_protocol_shutdown(void) {
1196 if (server->reconnect_timeout)
1197 server->poll_api->timeout_free(server->reconnect_timeout);