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-watch-glue.h>
47 #include <avahi-common/alternative.h>
48 #include <avahi-common/error.h>
49 #include <avahi-common/domain.h>
50 #include <avahi-common/timeval.h>
52 #include <avahi-core/log.h>
53 #include <avahi-core/core.h>
54 #include <avahi-core/lookup.h>
55 #include <avahi-core/publish.h>
57 #include "dbus-protocol.h"
58 #include "dbus-util.h"
59 #include "dbus-internal.h"
62 /* #define VALGRIND_WORKAROUND 1 */
64 #define RECONNECT_MSEC 3000
66 Server *server = NULL;
68 static int disable_user_service_publishing = 0;
70 static int dbus_connect(void);
71 static void dbus_disconnect(void);
73 static void client_free(Client *c) {
78 while (c->entry_groups)
79 avahi_dbus_entry_group_free(c->entry_groups);
81 while (c->sync_host_name_resolvers)
82 avahi_dbus_sync_host_name_resolver_free(c->sync_host_name_resolvers);
84 while (c->async_host_name_resolvers)
85 avahi_dbus_async_host_name_resolver_free(c->async_host_name_resolvers);
87 while (c->sync_address_resolvers)
88 avahi_dbus_sync_address_resolver_free(c->sync_address_resolvers);
90 while (c->async_address_resolvers)
91 avahi_dbus_async_address_resolver_free(c->async_address_resolvers);
93 while (c->domain_browsers)
94 avahi_dbus_domain_browser_free(c->domain_browsers);
96 while (c->service_type_browsers)
97 avahi_dbus_service_type_browser_free(c->service_type_browsers);
99 while (c->service_browsers)
100 avahi_dbus_service_browser_free(c->service_browsers);
102 while (c->sync_service_resolvers)
103 avahi_dbus_sync_service_resolver_free(c->sync_service_resolvers);
105 while (c->async_service_resolvers)
106 avahi_dbus_async_service_resolver_free(c->async_service_resolvers);
108 while (c->record_browsers)
109 avahi_dbus_record_browser_free(c->record_browsers);
111 assert(c->n_objects == 0);
114 AVAHI_LLIST_REMOVE(Client, clients, server->clients, c);
117 server->n_clients --;
118 assert(server->n_clients >= 0);
121 static Client *client_get(const char *name, int create) {
127 for (client = server->clients; client; client = client->clients_next)
128 if (!strcmp(name, client->name))
134 if (server->n_clients >= CLIENTS_MAX)
137 /* If not existant yet, create a new entry */
138 client = avahi_new(Client, 1);
139 client->id = server->current_id++;
140 client->name = avahi_strdup(name);
141 client->current_id = 0;
142 client->n_objects = 0;
144 AVAHI_LLIST_HEAD_INIT(EntryGroupInfo, client->entry_groups);
145 AVAHI_LLIST_HEAD_INIT(SyncHostNameResolverInfo, client->sync_host_name_resolvers);
146 AVAHI_LLIST_HEAD_INIT(AsyncHostNameResolverInfo, client->async_host_name_resolvers);
147 AVAHI_LLIST_HEAD_INIT(SyncAddressResolverInfo, client->sync_address_resolvers);
148 AVAHI_LLIST_HEAD_INIT(AsyncAddressResolverInfo, client->async_address_resolvers);
149 AVAHI_LLIST_HEAD_INIT(DomainBrowserInfo, client->domain_browsers);
150 AVAHI_LLIST_HEAD_INIT(ServiceTypeBrowserInfo, client->service_type_browsers);
151 AVAHI_LLIST_HEAD_INIT(ServiceBrowserInfo, client->service_browsers);
152 AVAHI_LLIST_HEAD_INIT(SyncServiceResolverInfo, client->sync_service_resolvers);
153 AVAHI_LLIST_HEAD_INIT(AsyncServiceResolverInfo, client->async_service_resolvers);
154 AVAHI_LLIST_HEAD_INIT(RecordBrowserInfo, client->record_browsers);
156 AVAHI_LLIST_PREPEND(Client, clients, server->clients, client);
159 assert(server->n_clients > 0);
164 static void reconnect_callback(AvahiTimeout *t, AVAHI_GCC_UNUSED void *userdata) {
165 assert(!server->bus);
167 if (dbus_connect() < 0) {
169 avahi_log_debug(__FILE__": Connection failed, retrying in %ims...", RECONNECT_MSEC);
170 avahi_elapse_time(&tv, RECONNECT_MSEC, 0);
171 server->poll_api->timeout_update(t, &tv);
173 avahi_log_debug(__FILE__": Successfully reconnected.");
174 server->poll_api->timeout_update(t, NULL);
178 static DBusHandlerResult msg_signal_filter_impl(AVAHI_GCC_UNUSED DBusConnection *c, DBusMessage *m, AVAHI_GCC_UNUSED void *userdata) {
181 dbus_error_init(&error);
183 /* avahi_log_debug(__FILE__": interface=%s, path=%s, member=%s", */
184 /* dbus_message_get_interface(m), */
185 /* dbus_message_get_path(m), */
186 /* dbus_message_get_member(m)); */
188 if (dbus_message_is_signal(m, DBUS_INTERFACE_LOCAL, "Disconnected")) {
191 if (server->reconnect) {
192 avahi_log_warn("Disconnnected from D-BUS, trying to reconnect in %ims...", RECONNECT_MSEC);
196 avahi_elapse_time(&tv, RECONNECT_MSEC, 0);
198 if (server->reconnect_timeout)
199 server->poll_api->timeout_update(server->reconnect_timeout, &tv);
201 server->reconnect_timeout = server->poll_api->timeout_new(server->poll_api, &tv, reconnect_callback, NULL);
203 avahi_log_warn("Disconnnected from D-BUS, exiting.");
207 return DBUS_HANDLER_RESULT_HANDLED;
209 } else if (dbus_message_is_signal(m, DBUS_INTERFACE_DBUS, "NameAcquired")) {
212 if (!dbus_message_get_args(m, &error, DBUS_TYPE_STRING, &name, DBUS_TYPE_INVALID)) {
213 avahi_log_warn("Error parsing NameAcquired message");
217 /* avahi_log_info(__FILE__": name acquired (%s)", name); */
218 return DBUS_HANDLER_RESULT_HANDLED;
220 } else if (dbus_message_is_signal(m, DBUS_INTERFACE_DBUS, "NameOwnerChanged")) {
221 char *name, *old, *new;
223 if (!dbus_message_get_args(m, &error, DBUS_TYPE_STRING, &name, DBUS_TYPE_STRING, &old, DBUS_TYPE_STRING, &new, DBUS_TYPE_INVALID)) {
224 avahi_log_warn("Error parsing NameOwnerChanged message");
231 if ((client = client_get(name, FALSE))) {
232 avahi_log_debug(__FILE__": client %s vanished.", name);
239 if (dbus_error_is_set(&error))
240 dbus_error_free(&error);
242 return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
245 static DBusHandlerResult msg_server_impl(DBusConnection *c, DBusMessage *m, AVAHI_GCC_UNUSED void *userdata) {
248 dbus_error_init(&error);
250 avahi_log_debug(__FILE__": interface=%s, path=%s, member=%s",
251 dbus_message_get_interface(m),
252 dbus_message_get_path(m),
253 dbus_message_get_member(m));
255 if (dbus_message_is_method_call(m, DBUS_INTERFACE_INTROSPECTABLE, "Introspect"))
256 return avahi_dbus_handle_introspect(c, m, "Server.introspect");
258 else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "GetHostName")) {
260 if (!dbus_message_get_args(m, &error, DBUS_TYPE_INVALID)) {
261 avahi_log_warn("Error parsing Server::GetHostName message");
265 return avahi_dbus_respond_string(c, m, avahi_server_get_host_name(avahi_server));
267 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "SetHostName")) {
271 if (!dbus_message_get_args(m, &error, DBUS_TYPE_STRING, &name, DBUS_TYPE_INVALID)) {
272 avahi_log_warn("Error parsing Server::SetHostName message");
276 if (avahi_server_set_host_name(avahi_server, name) < 0)
277 return avahi_dbus_respond_error(c, m, avahi_server_errno(avahi_server), NULL);
279 avahi_log_info("Changing host name to '%s'.", name);
281 return avahi_dbus_respond_ok(c, m);
283 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "GetDomainName")) {
285 if (!dbus_message_get_args(m, &error, DBUS_TYPE_INVALID)) {
286 avahi_log_warn("Error parsing Server::GetDomainName message");
290 return avahi_dbus_respond_string(c, m, avahi_server_get_domain_name(avahi_server));
292 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "GetHostNameFqdn")) {
294 if (!(dbus_message_get_args(m, &error, DBUS_TYPE_INVALID))) {
295 avahi_log_warn("Error parsing Server::GetHostNameFqdn message");
299 return avahi_dbus_respond_string(c, m, avahi_server_get_host_name_fqdn(avahi_server));
301 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "IsNSSSupportAvailable")) {
302 if (!(dbus_message_get_args(m, &error, DBUS_TYPE_INVALID))) {
303 avahi_log_warn("Error parsing Server::IsNSSSupportAvailable message");
307 return avahi_dbus_respond_boolean(c, m, nss_support);
309 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "GetVersionString")) {
311 if (!(dbus_message_get_args(m, &error, DBUS_TYPE_INVALID))) {
312 avahi_log_warn("Error parsing Server::GetVersionString message");
316 return avahi_dbus_respond_string(c, m, PACKAGE_STRING);
318 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "GetAPIVersion")) {
320 if (!(dbus_message_get_args(m, &error, DBUS_TYPE_INVALID))) {
321 avahi_log_warn("Error parsing Server::GetAPIVersion message");
325 return avahi_dbus_respond_uint32(c, m, AVAHI_DBUS_API_VERSION);
327 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "GetState")) {
328 AvahiServerState state;
330 if (!(dbus_message_get_args(m, &error, DBUS_TYPE_INVALID))) {
331 avahi_log_warn("Error parsing Server::GetState message");
335 state = avahi_server_get_state(avahi_server);
336 return avahi_dbus_respond_int32(c, m, (int32_t) state);
338 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "GetLocalServiceCookie")) {
340 if (!(dbus_message_get_args(m, &error, DBUS_TYPE_INVALID))) {
341 avahi_log_warn("Error parsing Server::GetLocalServiceCookie message");
345 return avahi_dbus_respond_uint32(c, m, avahi_server_get_local_service_cookie(avahi_server));
347 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "GetNetworkInterfaceNameByIndex")) {
350 char name[IF_NAMESIZE];
353 if (!(dbus_message_get_args(m, &error, DBUS_TYPE_INT32, &idx, DBUS_TYPE_INVALID))) {
354 avahi_log_warn("Error parsing Server::GetNetworkInterfaceNameByIndex message");
358 #ifdef VALGRIND_WORKAROUND
359 return respond_string(c, m, "blah");
362 if ((fd = socket(AF_INET, SOCK_DGRAM, 0)) < 0)
363 if ((fd = socket(AF_INET6, SOCK_DGRAM, 0)) < 0) {
365 snprintf(txt, sizeof(txt), "OS Error: %s", strerror(errno));
366 return avahi_dbus_respond_error(c, m, AVAHI_ERR_OS, txt);
369 if ((!if_indextoname(idx, name))) {
371 snprintf(txt, sizeof(txt), "OS Error: %s", strerror(errno));
373 return avahi_dbus_respond_error(c, m, AVAHI_ERR_OS, txt);
378 return avahi_dbus_respond_string(c, m, name);
381 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "GetNetworkInterfaceIndexByName")) {
386 if (!(dbus_message_get_args(m, &error, DBUS_TYPE_STRING, &n, DBUS_TYPE_INVALID)) || !n) {
387 avahi_log_warn("Error parsing Server::GetNetworkInterfaceIndexByName message");
391 #ifdef VALGRIND_WORKAROUND
392 return respond_int32(c, m, 1);
394 if ((fd = socket(AF_INET, SOCK_DGRAM, 0)) < 0)
395 if ((fd = socket(AF_INET6, SOCK_DGRAM, 0)) < 0) {
397 snprintf(txt, sizeof(txt), "OS Error: %s", strerror(errno));
398 return avahi_dbus_respond_error(c, m, AVAHI_ERR_OS, txt);
401 if (!(idx = if_nametoindex(n))) {
403 snprintf(txt, sizeof(txt), "OS Error: %s", strerror(errno));
405 return avahi_dbus_respond_error(c, m, AVAHI_ERR_OS, txt);
410 return avahi_dbus_respond_int32(c, m, idx);
413 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "GetAlternativeHostName")) {
416 if (!(dbus_message_get_args(m, &error, DBUS_TYPE_STRING, &n, DBUS_TYPE_INVALID)) || !n) {
417 avahi_log_warn("Error parsing Server::GetAlternativeHostName message");
421 t = avahi_alternative_host_name(n);
422 avahi_dbus_respond_string(c, m, t);
425 return DBUS_HANDLER_RESULT_HANDLED;
427 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "GetAlternativeServiceName")) {
430 if (!(dbus_message_get_args(m, &error, DBUS_TYPE_STRING, &n, DBUS_TYPE_INVALID)) || !n) {
431 avahi_log_warn("Error parsing Server::GetAlternativeServiceName message");
435 t = avahi_alternative_service_name(n);
436 avahi_dbus_respond_string(c, m, t);
439 return DBUS_HANDLER_RESULT_HANDLED;
441 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "EntryGroupNew")) {
444 static const DBusObjectPathVTable vtable = {
446 avahi_dbus_msg_entry_group_impl,
453 if (!dbus_message_get_args(m, &error, DBUS_TYPE_INVALID)) {
454 avahi_log_warn("Error parsing Server::EntryGroupNew message");
458 if (disable_user_service_publishing)
459 return avahi_dbus_respond_error(c, m, AVAHI_ERR_NOT_PERMITTED, NULL);
461 if (!(client = client_get(dbus_message_get_sender(m), TRUE))) {
462 avahi_log_warn("Too many clients, client request failed.");
463 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_CLIENTS, NULL);
466 if (client->n_objects >= OBJECTS_PER_CLIENT_MAX) {
467 avahi_log_warn("Too many objects for client '%s', client request failed.", client->name);
468 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_OBJECTS, NULL);
471 i = avahi_new(EntryGroupInfo, 1);
472 i->id = ++client->current_id;
476 AVAHI_LLIST_PREPEND(EntryGroupInfo, entry_groups, client->entry_groups, i);
479 if (!(i->entry_group = avahi_s_entry_group_new(avahi_server, avahi_dbus_entry_group_callback, i))) {
480 avahi_dbus_entry_group_free(i);
481 return avahi_dbus_respond_error(c, m, avahi_server_errno(avahi_server), NULL);
484 i->path = avahi_strdup_printf("/Client%u/EntryGroup%u", client->id, i->id);
485 dbus_connection_register_object_path(c, i->path, &vtable, i);
486 return avahi_dbus_respond_path(c, m, i->path);
488 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "ResolveHostName")) {
490 int32_t interface, protocol, aprotocol;
493 SyncHostNameResolverInfo *i;
495 if (!dbus_message_get_args(
497 DBUS_TYPE_INT32, &interface,
498 DBUS_TYPE_INT32, &protocol,
499 DBUS_TYPE_STRING, &name,
500 DBUS_TYPE_INT32, &aprotocol,
501 DBUS_TYPE_UINT32, &flags,
502 DBUS_TYPE_INVALID) || !name) {
503 avahi_log_warn("Error parsing Server::ResolveHostName message");
507 if (!(client = client_get(dbus_message_get_sender(m), TRUE))) {
508 avahi_log_warn("Too many clients, client request failed.");
509 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_CLIENTS, NULL);
512 if (client->n_objects >= OBJECTS_PER_CLIENT_MAX) {
513 avahi_log_warn("Too many objects for client '%s', client request failed.", client->name);
514 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_OBJECTS, NULL);
517 i = avahi_new(SyncHostNameResolverInfo, 1);
519 i->message = dbus_message_ref(m);
520 AVAHI_LLIST_PREPEND(SyncHostNameResolverInfo, sync_host_name_resolvers, client->sync_host_name_resolvers, i);
523 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))) {
524 avahi_dbus_sync_host_name_resolver_free(i);
525 return avahi_dbus_respond_error(c, m, avahi_server_errno(avahi_server), NULL);
528 return DBUS_HANDLER_RESULT_HANDLED;
530 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "ResolveAddress")) {
532 int32_t interface, protocol;
535 SyncAddressResolverInfo *i;
538 if (!dbus_message_get_args(
540 DBUS_TYPE_INT32, &interface,
541 DBUS_TYPE_INT32, &protocol,
542 DBUS_TYPE_STRING, &address,
543 DBUS_TYPE_UINT32, &flags,
544 DBUS_TYPE_INVALID) || !address) {
545 avahi_log_warn("Error parsing Server::ResolveAddress message");
549 if (!avahi_address_parse(address, AVAHI_PROTO_UNSPEC, &a))
550 return avahi_dbus_respond_error(c, m, AVAHI_ERR_INVALID_ADDRESS, NULL);
552 if (!(client = client_get(dbus_message_get_sender(m), TRUE))) {
553 avahi_log_warn("Too many clients, client request failed.");
554 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_CLIENTS, NULL);
557 if (client->n_objects >= OBJECTS_PER_CLIENT_MAX) {
558 avahi_log_warn("Too many objects for client '%s', client request failed.", client->name);
559 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_OBJECTS, NULL);
562 i = avahi_new(SyncAddressResolverInfo, 1);
564 i->message = dbus_message_ref(m);
565 AVAHI_LLIST_PREPEND(SyncAddressResolverInfo, sync_address_resolvers, client->sync_address_resolvers, i);
568 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))) {
569 avahi_dbus_sync_address_resolver_free(i);
570 return avahi_dbus_respond_error(c, m, avahi_server_errno(avahi_server), NULL);
573 return DBUS_HANDLER_RESULT_HANDLED;
575 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "DomainBrowserNew")) {
577 DomainBrowserInfo *i;
578 static const DBusObjectPathVTable vtable = {
580 avahi_dbus_msg_domain_browser_impl,
586 int32_t interface, protocol, type;
590 if (!dbus_message_get_args(
592 DBUS_TYPE_INT32, &interface,
593 DBUS_TYPE_INT32, &protocol,
594 DBUS_TYPE_STRING, &domain,
595 DBUS_TYPE_INT32, &type,
596 DBUS_TYPE_UINT32, &flags,
597 DBUS_TYPE_INVALID) || type < 0 || type >= AVAHI_DOMAIN_BROWSER_MAX) {
598 avahi_log_warn("Error parsing Server::DomainBrowserNew message");
602 if (!(client = client_get(dbus_message_get_sender(m), TRUE))) {
603 avahi_log_warn("Too many clients, client request failed.");
604 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_CLIENTS, NULL);
607 if (client->n_objects >= OBJECTS_PER_CLIENT_MAX) {
608 avahi_log_warn("Too many objects for client '%s', client request failed.", client->name);
609 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_OBJECTS, NULL);
615 i = avahi_new(DomainBrowserInfo, 1);
616 i->id = ++client->current_id;
619 AVAHI_LLIST_PREPEND(DomainBrowserInfo, domain_browsers, client->domain_browsers, i);
622 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))) {
623 avahi_dbus_domain_browser_free(i);
624 return avahi_dbus_respond_error(c, m, avahi_server_errno(avahi_server), NULL);
627 i->path = avahi_strdup_printf("/Client%u/DomainBrowser%u", client->id, i->id);
628 dbus_connection_register_object_path(c, i->path, &vtable, i);
629 return avahi_dbus_respond_path(c, m, i->path);
631 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "ServiceTypeBrowserNew")) {
633 ServiceTypeBrowserInfo *i;
634 static const DBusObjectPathVTable vtable = {
636 avahi_dbus_msg_service_type_browser_impl,
642 int32_t interface, protocol;
646 if (!dbus_message_get_args(
648 DBUS_TYPE_INT32, &interface,
649 DBUS_TYPE_INT32, &protocol,
650 DBUS_TYPE_STRING, &domain,
651 DBUS_TYPE_UINT32, &flags,
652 DBUS_TYPE_INVALID)) {
653 avahi_log_warn("Error parsing Server::ServiceTypeBrowserNew message");
657 if (!(client = client_get(dbus_message_get_sender(m), TRUE))) {
658 avahi_log_warn("Too many clients, client request failed.");
659 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_CLIENTS, NULL);
662 if (client->n_objects >= OBJECTS_PER_CLIENT_MAX) {
663 avahi_log_warn("Too many objects for client '%s', client request failed.", client->name);
664 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_OBJECTS, NULL);
670 i = avahi_new(ServiceTypeBrowserInfo, 1);
671 i->id = ++client->current_id;
674 AVAHI_LLIST_PREPEND(ServiceTypeBrowserInfo, service_type_browsers, client->service_type_browsers, i);
677 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))) {
678 avahi_dbus_service_type_browser_free(i);
679 return avahi_dbus_respond_error(c, m, avahi_server_errno(avahi_server), NULL);
682 i->path = avahi_strdup_printf("/Client%u/ServiceTypeBrowser%u", client->id, i->id);
683 dbus_connection_register_object_path(c, i->path, &vtable, i);
684 return avahi_dbus_respond_path(c, m, i->path);
686 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "ServiceBrowserNew")) {
688 ServiceBrowserInfo *i;
689 static const DBusObjectPathVTable vtable = {
691 avahi_dbus_msg_service_browser_impl,
697 int32_t interface, protocol;
701 if (!dbus_message_get_args(
703 DBUS_TYPE_INT32, &interface,
704 DBUS_TYPE_INT32, &protocol,
705 DBUS_TYPE_STRING, &type,
706 DBUS_TYPE_STRING, &domain,
707 DBUS_TYPE_UINT32, &flags,
708 DBUS_TYPE_INVALID) || !type) {
709 avahi_log_warn("Error parsing Server::ServiceBrowserNew message");
713 if (!(client = client_get(dbus_message_get_sender(m), TRUE))) {
714 avahi_log_warn("Too many clients, client request failed.");
715 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_CLIENTS, NULL);
718 if (client->n_objects >= OBJECTS_PER_CLIENT_MAX) {
719 avahi_log_warn("Too many objects for client '%s', client request failed.", client->name);
720 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_OBJECTS, NULL);
726 i = avahi_new(ServiceBrowserInfo, 1);
727 i->id = ++client->current_id;
730 AVAHI_LLIST_PREPEND(ServiceBrowserInfo, service_browsers, client->service_browsers, i);
733 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))) {
734 avahi_dbus_service_browser_free(i);
735 return avahi_dbus_respond_error(c, m, avahi_server_errno(avahi_server), NULL);
738 i->path = avahi_strdup_printf("/Client%u/ServiceBrowser%u", client->id, i->id);
739 dbus_connection_register_object_path(c, i->path, &vtable, i);
740 return avahi_dbus_respond_path(c, m, i->path);
742 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "ResolveService")) {
744 int32_t interface, protocol, aprotocol;
746 char *name, *type, *domain;
747 SyncServiceResolverInfo *i;
749 if (!dbus_message_get_args(
751 DBUS_TYPE_INT32, &interface,
752 DBUS_TYPE_INT32, &protocol,
753 DBUS_TYPE_STRING, &name,
754 DBUS_TYPE_STRING, &type,
755 DBUS_TYPE_STRING, &domain,
756 DBUS_TYPE_INT32, &aprotocol,
757 DBUS_TYPE_UINT32, &flags,
758 DBUS_TYPE_INVALID) || !type) {
759 avahi_log_warn("Error parsing Server::ResolveService message");
763 if (!(client = client_get(dbus_message_get_sender(m), TRUE))) {
764 avahi_log_warn("Too many clients, client request failed.");
765 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_CLIENTS, NULL);
768 if (client->n_objects >= OBJECTS_PER_CLIENT_MAX) {
769 avahi_log_warn("Too many objects for client '%s', client request failed.", client->name);
770 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_OBJECTS, NULL);
779 i = avahi_new(SyncServiceResolverInfo, 1);
781 i->message = dbus_message_ref(m);
782 AVAHI_LLIST_PREPEND(SyncServiceResolverInfo, sync_service_resolvers, client->sync_service_resolvers, i);
785 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))) {
786 avahi_dbus_sync_service_resolver_free(i);
787 return avahi_dbus_respond_error(c, m, avahi_server_errno(avahi_server), NULL);
790 return DBUS_HANDLER_RESULT_HANDLED;
792 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "ServiceResolverNew")) {
794 int32_t interface, protocol, aprotocol;
796 char *name, *type, *domain;
797 AsyncServiceResolverInfo *i;
798 static const DBusObjectPathVTable vtable = {
800 avahi_dbus_msg_async_service_resolver_impl,
807 if (!dbus_message_get_args(
809 DBUS_TYPE_INT32, &interface,
810 DBUS_TYPE_INT32, &protocol,
811 DBUS_TYPE_STRING, &name,
812 DBUS_TYPE_STRING, &type,
813 DBUS_TYPE_STRING, &domain,
814 DBUS_TYPE_INT32, &aprotocol,
815 DBUS_TYPE_UINT32, &flags,
816 DBUS_TYPE_INVALID) || !type) {
817 avahi_log_warn("Error parsing Server::ServiceResolverNew message");
821 if (!(client = client_get(dbus_message_get_sender(m), TRUE))) {
822 avahi_log_warn(__FILE__": Too many clients, client request failed.");
823 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_CLIENTS, NULL);
826 if (client->n_objects >= OBJECTS_PER_CLIENT_MAX) {
827 avahi_log_warn(__FILE__": Too many objects for client '%s', client request failed.", client->name);
828 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_OBJECTS, NULL);
837 i = avahi_new(AsyncServiceResolverInfo, 1);
838 i->id = ++client->current_id;
841 AVAHI_LLIST_PREPEND(AsyncServiceResolverInfo, async_service_resolvers, client->async_service_resolvers, i);
844 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))) {
845 avahi_dbus_async_service_resolver_free(i);
846 return avahi_dbus_respond_error(c, m, avahi_server_errno(avahi_server), NULL);
849 /* avahi_log_debug(__FILE__": [%s], new service resolver for <%s.%s.%s>", i->path, name, type, domain); */
851 i->path = avahi_strdup_printf("/Client%u/ServiceResolver%u", client->id, i->id);
852 dbus_connection_register_object_path(c, i->path, &vtable, i);
853 return avahi_dbus_respond_path(c, m, i->path);
855 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "HostNameResolverNew")) {
857 int32_t interface, protocol, aprotocol;
860 AsyncHostNameResolverInfo *i;
861 static const DBusObjectPathVTable vtable = {
863 avahi_dbus_msg_async_host_name_resolver_impl,
870 if (!dbus_message_get_args(
872 DBUS_TYPE_INT32, &interface,
873 DBUS_TYPE_INT32, &protocol,
874 DBUS_TYPE_STRING, &name,
875 DBUS_TYPE_INT32, &aprotocol,
876 DBUS_TYPE_UINT32, &flags,
877 DBUS_TYPE_INVALID) || !name) {
878 avahi_log_warn("Error parsing Server::HostNameResolverNew message");
882 if (!(client = client_get(dbus_message_get_sender(m), TRUE))) {
883 avahi_log_warn(__FILE__": Too many clients, client request failed.");
884 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_CLIENTS, NULL);
887 if (client->n_objects >= OBJECTS_PER_CLIENT_MAX) {
888 avahi_log_warn(__FILE__": Too many objects for client '%s', client request failed.", client->name);
889 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_OBJECTS, NULL);
892 i = avahi_new(AsyncHostNameResolverInfo, 1);
893 i->id = ++client->current_id;
896 AVAHI_LLIST_PREPEND(AsyncHostNameResolverInfo, async_host_name_resolvers, client->async_host_name_resolvers, i);
899 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))) {
900 avahi_dbus_async_host_name_resolver_free(i);
901 return avahi_dbus_respond_error(c, m, avahi_server_errno(avahi_server), NULL);
904 i->path = avahi_strdup_printf("/Client%u/HostNameResolver%u", client->id, i->id);
905 dbus_connection_register_object_path(c, i->path, &vtable, i);
906 return avahi_dbus_respond_path(c, m, i->path);
908 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "AddressResolverNew")) {
910 int32_t interface, protocol;
913 AsyncAddressResolverInfo *i;
915 static const DBusObjectPathVTable vtable = {
917 avahi_dbus_msg_async_address_resolver_impl,
924 if (!dbus_message_get_args(
926 DBUS_TYPE_INT32, &interface,
927 DBUS_TYPE_INT32, &protocol,
928 DBUS_TYPE_STRING, &address,
929 DBUS_TYPE_UINT32, &flags,
930 DBUS_TYPE_INVALID) || !address) {
931 avahi_log_warn("Error parsing Server::AddressResolverNew message");
935 if (!avahi_address_parse(address, AVAHI_PROTO_UNSPEC, &a))
936 return avahi_dbus_respond_error(c, m, AVAHI_ERR_INVALID_ADDRESS, NULL);
938 if (!(client = client_get(dbus_message_get_sender(m), TRUE))) {
939 avahi_log_warn(__FILE__": Too many clients, client request failed.");
940 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_CLIENTS, NULL);
943 if (client->n_objects >= OBJECTS_PER_CLIENT_MAX) {
944 avahi_log_warn(__FILE__": Too many objects for client '%s', client request failed.", client->name);
945 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_OBJECTS, NULL);
948 i = avahi_new(AsyncAddressResolverInfo, 1);
949 i->id = ++client->current_id;
952 AVAHI_LLIST_PREPEND(AsyncAddressResolverInfo, async_address_resolvers, client->async_address_resolvers, i);
955 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))) {
956 avahi_dbus_async_address_resolver_free(i);
957 return avahi_dbus_respond_error(c, m, avahi_server_errno(avahi_server), NULL);
960 i->path = avahi_strdup_printf("/Client%u/AddressResolver%u", client->id, i->id);
961 dbus_connection_register_object_path(c, i->path, &vtable, i);
962 return avahi_dbus_respond_path(c, m, i->path);
964 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "RecordBrowserNew")) {
966 RecordBrowserInfo *i;
967 static const DBusObjectPathVTable vtable = {
969 avahi_dbus_msg_record_browser_impl,
975 int32_t interface, protocol;
978 uint16_t type, clazz;
981 if (!dbus_message_get_args(
983 DBUS_TYPE_INT32, &interface,
984 DBUS_TYPE_INT32, &protocol,
985 DBUS_TYPE_STRING, &name,
986 DBUS_TYPE_UINT16, &clazz,
987 DBUS_TYPE_UINT16, &type,
988 DBUS_TYPE_UINT32, &flags,
989 DBUS_TYPE_INVALID) || !name) {
990 avahi_log_warn("Error parsing Server::RecordBrowserNew message");
994 if (!avahi_is_valid_domain_name(name))
995 return avahi_dbus_respond_error(c, m, AVAHI_ERR_INVALID_DOMAIN_NAME, NULL);
997 if (!(client = client_get(dbus_message_get_sender(m), TRUE))) {
998 avahi_log_warn("Too many clients, client request failed.");
999 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_CLIENTS, NULL);
1002 if (client->n_objects >= OBJECTS_PER_CLIENT_MAX) {
1003 avahi_log_warn("Too many objects for client '%s', client request failed.", client->name);
1004 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_OBJECTS, NULL);
1007 i = avahi_new(RecordBrowserInfo, 1);
1008 i->id = ++client->current_id;
1011 AVAHI_LLIST_PREPEND(RecordBrowserInfo, record_browsers, client->record_browsers, i);
1012 client->n_objects++;
1014 key = avahi_key_new(name, clazz, type);
1017 if (!(i->record_browser = avahi_s_record_browser_new(avahi_server, (AvahiIfIndex) interface, (AvahiProtocol) protocol, key, (AvahiLookupFlags) flags, avahi_dbus_record_browser_callback, i))) {
1018 avahi_key_unref(key);
1019 avahi_dbus_record_browser_free(i);
1020 return avahi_dbus_respond_error(c, m, avahi_server_errno(avahi_server), NULL);
1023 avahi_key_unref(key);
1025 i->path = avahi_strdup_printf("/Client%u/RecordBrowser%u", client->id, i->id);
1026 dbus_connection_register_object_path(c, i->path, &vtable, i);
1027 return avahi_dbus_respond_path(c, m, i->path);
1030 avahi_log_warn("Missed message %s::%s()", dbus_message_get_interface(m), dbus_message_get_member(m));
1033 if (dbus_error_is_set(&error))
1034 dbus_error_free(&error);
1036 return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
1039 void dbus_protocol_server_state_changed(AvahiServerState state) {
1044 if (!server || !server->bus)
1047 m = dbus_message_new_signal(AVAHI_DBUS_PATH_SERVER, AVAHI_DBUS_INTERFACE_SERVER, "StateChanged");
1048 t = (int32_t) state;
1050 if (state == AVAHI_SERVER_COLLISION)
1051 e = AVAHI_DBUS_ERR_COLLISION;
1052 else if (state == AVAHI_SERVER_FAILURE)
1053 e = avahi_error_number_to_dbus(avahi_server_errno(avahi_server));
1055 e = AVAHI_DBUS_ERR_OK;
1057 dbus_message_append_args(m, DBUS_TYPE_INT32, &t, DBUS_TYPE_STRING, &e, DBUS_TYPE_INVALID);
1058 dbus_connection_send(server->bus, m, NULL);
1059 dbus_message_unref(m);
1062 static int dbus_connect(void) {
1065 static const DBusObjectPathVTable server_vtable = {
1075 assert(!server->bus);
1077 dbus_error_init(&error);
1079 if (!(server->bus = dbus_bus_get(DBUS_BUS_SYSTEM, &error))) {
1080 assert(dbus_error_is_set(&error));
1081 avahi_log_error("dbus_bus_get(): %s", error.message);
1084 if (avahi_dbus_connection_glue(server->bus, server->poll_api) < 0) {
1085 avahi_log_error("avahi_dbus_connection_glue() failed");
1089 dbus_connection_set_exit_on_disconnect(server->bus, FALSE);
1091 if (dbus_bus_request_name(
1094 #if (DBUS_VERSION_MAJOR == 0) && (DBUS_VERSION_MINOR >= 60)
1095 DBUS_NAME_FLAG_DO_NOT_QUEUE,
1097 DBUS_NAME_FLAG_PROHIBIT_REPLACEMENT,
1099 &error) != DBUS_REQUEST_NAME_REPLY_PRIMARY_OWNER) {
1100 if (dbus_error_is_set(&error)) {
1101 avahi_log_error("dbus_bus_request_name(): %s", error.message);
1105 avahi_log_error("Failed to acquire DBUS name '"AVAHI_DBUS_NAME"'");
1109 if (!(dbus_connection_add_filter(server->bus, msg_signal_filter_impl, (void*) server->poll_api, NULL))) {
1110 avahi_log_error("dbus_connection_add_filter() failed");
1114 dbus_bus_add_match(server->bus, "type='signal',""interface='" DBUS_INTERFACE_DBUS "'", &error);
1116 if (dbus_error_is_set(&error)) {
1117 avahi_log_error("dbus_bus_add_match(): %s", error.message);
1121 if (!(dbus_connection_register_object_path(server->bus, AVAHI_DBUS_PATH_SERVER, &server_vtable, NULL))) {
1122 avahi_log_error("dbus_connection_register_object_path() failed");
1129 if (dbus_error_is_set(&error))
1130 dbus_error_free(&error);
1133 #if (DBUS_VERSION_MAJOR == 0) && (DBUS_VERSION_MINOR >= 62)
1134 dbus_connection_close(server->bus);
1136 dbus_connection_disconnect(server->bus);
1138 dbus_connection_unref(server->bus);
1145 static void dbus_disconnect(void) {
1148 while (server->clients)
1149 client_free(server->clients);
1151 assert(server->n_clients == 0);
1154 #if (DBUS_VERSION_MAJOR == 0) && (DBUS_VERSION_MINOR >= 62)
1155 dbus_connection_close(server->bus);
1157 dbus_connection_disconnect(server->bus);
1159 dbus_connection_unref(server->bus);
1164 int dbus_protocol_setup(const AvahiPoll *poll_api, int _disable_user_service_publishing, int force) {
1166 disable_user_service_publishing = _disable_user_service_publishing;
1168 server = avahi_new(Server, 1);
1169 AVAHI_LLIST_HEAD_INIT(Clients, server->clients);
1170 server->current_id = 0;
1171 server->n_clients = 0;
1173 server->poll_api = poll_api;
1174 server->reconnect_timeout = NULL;
1175 server->reconnect = force;
1177 if (dbus_connect() < 0) {
1183 avahi_log_warn("WARNING: Failed to contact D-BUS daemon, retrying in %ims.", RECONNECT_MSEC);
1185 avahi_elapse_time(&tv, RECONNECT_MSEC, 0);
1186 server->reconnect_timeout = server->poll_api->timeout_new(server->poll_api, &tv, reconnect_callback, NULL);
1193 #if (DBUS_VERSION_MAJOR == 0) && (DBUS_VERSION_MINOR >= 62)
1194 dbus_connection_close(server->bus);
1196 dbus_connection_disconnect(server->bus);
1198 dbus_connection_unref(server->bus);
1206 void dbus_protocol_shutdown(void) {
1211 if (server->reconnect_timeout)
1212 server->poll_api->timeout_free(server->reconnect_timeout);