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>
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 Server *server = NULL;
66 static int disable_user_service_publishing = 0;
68 static void client_free(Client *c) {
73 while (c->entry_groups)
74 avahi_dbus_entry_group_free(c->entry_groups);
76 while (c->sync_host_name_resolvers)
77 avahi_dbus_sync_host_name_resolver_free(c->sync_host_name_resolvers);
79 while (c->async_host_name_resolvers)
80 avahi_dbus_async_host_name_resolver_free(c->async_host_name_resolvers);
82 while (c->sync_address_resolvers)
83 avahi_dbus_sync_address_resolver_free(c->sync_address_resolvers);
85 while (c->async_address_resolvers)
86 avahi_dbus_async_address_resolver_free(c->async_address_resolvers);
88 while (c->domain_browsers)
89 avahi_dbus_domain_browser_free(c->domain_browsers);
91 while (c->service_type_browsers)
92 avahi_dbus_service_type_browser_free(c->service_type_browsers);
94 while (c->service_browsers)
95 avahi_dbus_service_browser_free(c->service_browsers);
97 while (c->sync_service_resolvers)
98 avahi_dbus_sync_service_resolver_free(c->sync_service_resolvers);
100 while (c->async_service_resolvers)
101 avahi_dbus_async_service_resolver_free(c->async_service_resolvers);
103 while (c->record_browsers)
104 avahi_dbus_record_browser_free(c->record_browsers);
106 assert(c->n_objects == 0);
109 AVAHI_LLIST_REMOVE(Client, clients, server->clients, c);
112 server->n_clients --;
113 assert(server->n_clients >= 0);
116 static Client *client_get(const char *name, int create) {
122 for (client = server->clients; client; client = client->clients_next)
123 if (!strcmp(name, client->name))
129 if (server->n_clients >= CLIENTS_MAX)
132 /* If not existant yet, create a new entry */
133 client = avahi_new(Client, 1);
134 client->id = server->current_id++;
135 client->name = avahi_strdup(name);
136 client->current_id = 0;
137 client->n_objects = 0;
139 AVAHI_LLIST_HEAD_INIT(EntryGroupInfo, client->entry_groups);
140 AVAHI_LLIST_HEAD_INIT(SyncHostNameResolverInfo, client->sync_host_name_resolvers);
141 AVAHI_LLIST_HEAD_INIT(AsyncHostNameResolverInfo, client->async_host_name_resolvers);
142 AVAHI_LLIST_HEAD_INIT(SyncAddressResolverInfo, client->sync_address_resolvers);
143 AVAHI_LLIST_HEAD_INIT(AsyncAddressResolverInfo, client->async_address_resolvers);
144 AVAHI_LLIST_HEAD_INIT(DomainBrowserInfo, client->domain_browsers);
145 AVAHI_LLIST_HEAD_INIT(ServiceTypeBrowserInfo, client->service_type_browsers);
146 AVAHI_LLIST_HEAD_INIT(ServiceBrowserInfo, client->service_browsers);
147 AVAHI_LLIST_HEAD_INIT(SyncServiceResolverInfo, client->sync_service_resolvers);
148 AVAHI_LLIST_HEAD_INIT(AsyncServiceResolverInfo, client->async_service_resolvers);
149 AVAHI_LLIST_HEAD_INIT(RecordBrowserInfo, client->record_browsers);
151 AVAHI_LLIST_PREPEND(Client, clients, server->clients, client);
154 assert(server->n_clients > 0);
160 static DBusHandlerResult msg_signal_filter_impl(AVAHI_GCC_UNUSED DBusConnection *c, DBusMessage *m, AVAHI_GCC_UNUSED void *userdata) {
163 dbus_error_init(&error);
165 /* avahi_log_debug(__FILE__": interface=%s, path=%s, member=%s", */
166 /* dbus_message_get_interface(m), */
167 /* dbus_message_get_path(m), */
168 /* dbus_message_get_member(m)); */
170 if (dbus_message_is_signal(m, DBUS_INTERFACE_LOCAL, "Disconnected")) {
171 /* No, we shouldn't quit, but until we get somewhere
172 * usefull such that we can restore our state, we will */
173 avahi_log_warn("Disconnnected from D-BUS, terminating...");
175 raise(SIGQUIT); /* The signal handler will catch this and terminate the process cleanly*/
177 return DBUS_HANDLER_RESULT_HANDLED;
179 } else if (dbus_message_is_signal(m, DBUS_INTERFACE_DBUS, "NameAcquired")) {
182 if (!dbus_message_get_args(m, &error, DBUS_TYPE_STRING, &name, DBUS_TYPE_INVALID)) {
183 avahi_log_warn("Error parsing NameAcquired message");
187 /* avahi_log_info(__FILE__": name acquired (%s)", name); */
188 return DBUS_HANDLER_RESULT_HANDLED;
190 } else if (dbus_message_is_signal(m, DBUS_INTERFACE_DBUS, "NameOwnerChanged")) {
191 char *name, *old, *new;
193 if (!dbus_message_get_args(m, &error, DBUS_TYPE_STRING, &name, DBUS_TYPE_STRING, &old, DBUS_TYPE_STRING, &new, DBUS_TYPE_INVALID)) {
194 avahi_log_warn("Error parsing NameOwnerChanged message");
201 if ((client = client_get(name, FALSE))) {
202 avahi_log_debug(__FILE__": client %s vanished.", name);
209 if (dbus_error_is_set(&error))
210 dbus_error_free(&error);
212 return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
215 static DBusHandlerResult msg_server_impl(DBusConnection *c, DBusMessage *m, AVAHI_GCC_UNUSED void *userdata) {
218 dbus_error_init(&error);
220 avahi_log_debug(__FILE__": interface=%s, path=%s, member=%s",
221 dbus_message_get_interface(m),
222 dbus_message_get_path(m),
223 dbus_message_get_member(m));
225 if (dbus_message_is_method_call(m, DBUS_INTERFACE_INTROSPECTABLE, "Introspect"))
226 return avahi_dbus_handle_introspect(c, m, "Server.introspect");
228 else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "GetHostName")) {
230 if (!dbus_message_get_args(m, &error, DBUS_TYPE_INVALID)) {
231 avahi_log_warn("Error parsing Server::GetHostName message");
235 return avahi_dbus_respond_string(c, m, avahi_server_get_host_name(avahi_server));
237 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "GetDomainName")) {
239 if (!dbus_message_get_args(m, &error, DBUS_TYPE_INVALID)) {
240 avahi_log_warn("Error parsing Server::GetDomainName message");
244 return avahi_dbus_respond_string(c, m, avahi_server_get_domain_name(avahi_server));
246 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "GetHostNameFqdn")) {
248 if (!(dbus_message_get_args(m, &error, DBUS_TYPE_INVALID))) {
249 avahi_log_warn("Error parsing Server::GetHostNameFqdn message");
253 return avahi_dbus_respond_string(c, m, avahi_server_get_host_name_fqdn(avahi_server));
255 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "GetVersionString")) {
257 if (!(dbus_message_get_args(m, &error, DBUS_TYPE_INVALID))) {
258 avahi_log_warn("Error parsing Server::GetVersionString message");
262 return avahi_dbus_respond_string(c, m, PACKAGE_STRING);
264 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "GetState")) {
265 AvahiServerState state;
267 if (!(dbus_message_get_args(m, &error, DBUS_TYPE_INVALID))) {
268 avahi_log_warn("Error parsing Server::GetState message");
272 state = avahi_server_get_state(avahi_server);
273 return avahi_dbus_respond_int32(c, m, (int32_t) state);
275 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "GetLocalServiceCookie")) {
277 if (!(dbus_message_get_args(m, &error, DBUS_TYPE_INVALID))) {
278 avahi_log_warn("Error parsing Server::GetLocalServiceCookie message");
282 return avahi_dbus_respond_uint32(c, m, avahi_server_get_local_service_cookie(avahi_server));
284 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "GetNetworkInterfaceNameByIndex")) {
287 char name[IF_NAMESIZE];
290 if (!(dbus_message_get_args(m, &error, DBUS_TYPE_INT32, &idx, DBUS_TYPE_INVALID))) {
291 avahi_log_warn("Error parsing Server::GetNetworkInterfaceNameByIndex message");
295 #ifdef VALGRIND_WORKAROUND
296 return respond_string(c, m, "blah");
299 if ((fd = socket(AF_INET, SOCK_DGRAM, 0)) < 0)
300 if ((fd = socket(AF_INET6, SOCK_DGRAM, 0)) < 0) {
302 snprintf(txt, sizeof(txt), "OS Error: %s", strerror(errno));
303 return avahi_dbus_respond_error(c, m, AVAHI_ERR_OS, txt);
306 if ((!if_indextoname(idx, name))) {
308 snprintf(txt, sizeof(txt), "OS Error: %s", strerror(errno));
310 return avahi_dbus_respond_error(c, m, AVAHI_ERR_OS, txt);
315 return avahi_dbus_respond_string(c, m, name);
318 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "GetNetworkInterfaceIndexByName")) {
323 if (!(dbus_message_get_args(m, &error, DBUS_TYPE_STRING, &n, DBUS_TYPE_INVALID)) || !n) {
324 avahi_log_warn("Error parsing Server::GetNetworkInterfaceIndexByName message");
328 #ifdef VALGRIND_WORKAROUND
329 return respond_int32(c, m, 1);
331 if ((fd = socket(AF_INET, SOCK_DGRAM, 0)) < 0)
332 if ((fd = socket(AF_INET6, SOCK_DGRAM, 0)) < 0) {
334 snprintf(txt, sizeof(txt), "OS Error: %s", strerror(errno));
335 return avahi_dbus_respond_error(c, m, AVAHI_ERR_OS, txt);
338 if (!(idx = if_nametoindex(n))) {
340 snprintf(txt, sizeof(txt), "OS Error: %s", strerror(errno));
342 return avahi_dbus_respond_error(c, m, AVAHI_ERR_OS, txt);
347 return avahi_dbus_respond_int32(c, m, idx);
350 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "GetAlternativeHostName")) {
353 if (!(dbus_message_get_args(m, &error, DBUS_TYPE_STRING, &n, DBUS_TYPE_INVALID)) || !n) {
354 avahi_log_warn("Error parsing Server::GetAlternativeHostName message");
358 t = avahi_alternative_host_name(n);
359 avahi_dbus_respond_string(c, m, t);
362 return DBUS_HANDLER_RESULT_HANDLED;
364 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "GetAlternativeServiceName")) {
367 if (!(dbus_message_get_args(m, &error, DBUS_TYPE_STRING, &n, DBUS_TYPE_INVALID)) || !n) {
368 avahi_log_warn("Error parsing Server::GetAlternativeServiceName message");
372 t = avahi_alternative_service_name(n);
373 avahi_dbus_respond_string(c, m, t);
376 return DBUS_HANDLER_RESULT_HANDLED;
378 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "EntryGroupNew")) {
381 static const DBusObjectPathVTable vtable = {
383 avahi_dbus_msg_entry_group_impl,
390 if (!dbus_message_get_args(m, &error, DBUS_TYPE_INVALID)) {
391 avahi_log_warn("Error parsing Server::EntryGroupNew message");
395 if (disable_user_service_publishing)
396 return avahi_dbus_respond_error(c, m, AVAHI_ERR_NOT_PERMITTED, NULL);
398 if (!(client = client_get(dbus_message_get_sender(m), TRUE))) {
399 avahi_log_warn("Too many clients, client request failed.");
400 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_CLIENTS, NULL);
403 if (client->n_objects >= OBJECTS_PER_CLIENT_MAX) {
404 avahi_log_warn("Too many objects for client '%s', client request failed.", client->name);
405 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_OBJECTS, NULL);
408 i = avahi_new(EntryGroupInfo, 1);
409 i->id = ++client->current_id;
411 i->path = avahi_strdup_printf("/Client%u/EntryGroup%u", client->id, i->id);
413 AVAHI_LLIST_PREPEND(EntryGroupInfo, entry_groups, client->entry_groups, i);
416 if (!(i->entry_group = avahi_s_entry_group_new(avahi_server, avahi_dbus_entry_group_callback, i))) {
417 avahi_dbus_entry_group_free(i);
418 return avahi_dbus_respond_error(c, m, avahi_server_errno(avahi_server), NULL);
421 dbus_connection_register_object_path(c, i->path, &vtable, i);
422 return avahi_dbus_respond_path(c, m, i->path);
424 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "ResolveHostName")) {
426 int32_t interface, protocol, aprotocol;
429 SyncHostNameResolverInfo *i;
431 if (!dbus_message_get_args(
433 DBUS_TYPE_INT32, &interface,
434 DBUS_TYPE_INT32, &protocol,
435 DBUS_TYPE_STRING, &name,
436 DBUS_TYPE_INT32, &aprotocol,
437 DBUS_TYPE_UINT32, &flags,
438 DBUS_TYPE_INVALID) || !name) {
439 avahi_log_warn("Error parsing Server::ResolveHostName message");
443 if (!(client = client_get(dbus_message_get_sender(m), TRUE))) {
444 avahi_log_warn("Too many clients, client request failed.");
445 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_CLIENTS, NULL);
448 if (client->n_objects >= OBJECTS_PER_CLIENT_MAX) {
449 avahi_log_warn("Too many objects for client '%s', client request failed.", client->name);
450 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_OBJECTS, NULL);
453 i = avahi_new(SyncHostNameResolverInfo, 1);
455 i->message = dbus_message_ref(m);
456 AVAHI_LLIST_PREPEND(SyncHostNameResolverInfo, sync_host_name_resolvers, client->sync_host_name_resolvers, i);
459 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))) {
460 avahi_dbus_sync_host_name_resolver_free(i);
461 return avahi_dbus_respond_error(c, m, avahi_server_errno(avahi_server), NULL);
464 return DBUS_HANDLER_RESULT_HANDLED;
466 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "ResolveAddress")) {
468 int32_t interface, protocol;
471 SyncAddressResolverInfo *i;
474 if (!dbus_message_get_args(
476 DBUS_TYPE_INT32, &interface,
477 DBUS_TYPE_INT32, &protocol,
478 DBUS_TYPE_STRING, &address,
479 DBUS_TYPE_UINT32, &flags,
480 DBUS_TYPE_INVALID) || !address) {
481 avahi_log_warn("Error parsing Server::ResolveAddress message");
485 if (!avahi_address_parse(address, AVAHI_PROTO_UNSPEC, &a))
486 return avahi_dbus_respond_error(c, m, AVAHI_ERR_INVALID_ADDRESS, NULL);
488 if (!(client = client_get(dbus_message_get_sender(m), TRUE))) {
489 avahi_log_warn("Too many clients, client request failed.");
490 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_CLIENTS, NULL);
493 if (client->n_objects >= OBJECTS_PER_CLIENT_MAX) {
494 avahi_log_warn("Too many objects for client '%s', client request failed.", client->name);
495 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_OBJECTS, NULL);
498 i = avahi_new(SyncAddressResolverInfo, 1);
500 i->message = dbus_message_ref(m);
501 AVAHI_LLIST_PREPEND(SyncAddressResolverInfo, sync_address_resolvers, client->sync_address_resolvers, i);
504 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))) {
505 avahi_dbus_sync_address_resolver_free(i);
506 return avahi_dbus_respond_error(c, m, avahi_server_errno(avahi_server), NULL);
509 return DBUS_HANDLER_RESULT_HANDLED;
511 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "DomainBrowserNew")) {
513 DomainBrowserInfo *i;
514 static const DBusObjectPathVTable vtable = {
516 avahi_dbus_msg_domain_browser_impl,
522 int32_t interface, protocol, type;
526 if (!dbus_message_get_args(
528 DBUS_TYPE_INT32, &interface,
529 DBUS_TYPE_INT32, &protocol,
530 DBUS_TYPE_STRING, &domain,
531 DBUS_TYPE_INT32, &type,
532 DBUS_TYPE_UINT32, &flags,
533 DBUS_TYPE_INVALID) || type < 0 || type >= AVAHI_DOMAIN_BROWSER_MAX) {
534 avahi_log_warn("Error parsing Server::DomainBrowserNew message");
538 if (!(client = client_get(dbus_message_get_sender(m), TRUE))) {
539 avahi_log_warn("Too many clients, client request failed.");
540 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_CLIENTS, NULL);
543 if (client->n_objects >= OBJECTS_PER_CLIENT_MAX) {
544 avahi_log_warn("Too many objects for client '%s', client request failed.", client->name);
545 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_OBJECTS, NULL);
551 i = avahi_new(DomainBrowserInfo, 1);
552 i->id = ++client->current_id;
554 i->path = avahi_strdup_printf("/Client%u/DomainBrowser%u", client->id, i->id);
555 AVAHI_LLIST_PREPEND(DomainBrowserInfo, domain_browsers, client->domain_browsers, i);
558 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))) {
559 avahi_dbus_domain_browser_free(i);
560 return avahi_dbus_respond_error(c, m, avahi_server_errno(avahi_server), NULL);
563 dbus_connection_register_object_path(c, i->path, &vtable, i);
564 return avahi_dbus_respond_path(c, m, i->path);
566 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "ServiceTypeBrowserNew")) {
568 ServiceTypeBrowserInfo *i;
569 static const DBusObjectPathVTable vtable = {
571 avahi_dbus_msg_service_type_browser_impl,
577 int32_t interface, protocol;
581 if (!dbus_message_get_args(
583 DBUS_TYPE_INT32, &interface,
584 DBUS_TYPE_INT32, &protocol,
585 DBUS_TYPE_STRING, &domain,
586 DBUS_TYPE_UINT32, &flags,
587 DBUS_TYPE_INVALID)) {
588 avahi_log_warn("Error parsing Server::ServiceTypeBrowserNew message");
592 if (!(client = client_get(dbus_message_get_sender(m), TRUE))) {
593 avahi_log_warn("Too many clients, client request failed.");
594 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_CLIENTS, NULL);
598 if (client->n_objects >= OBJECTS_PER_CLIENT_MAX) {
599 avahi_log_warn("Too many objects for client '%s', client request failed.", client->name);
600 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_OBJECTS, NULL);
606 i = avahi_new(ServiceTypeBrowserInfo, 1);
607 i->id = ++client->current_id;
609 i->path = avahi_strdup_printf("/Client%u/ServiceTypeBrowser%u", client->id, i->id);
610 AVAHI_LLIST_PREPEND(ServiceTypeBrowserInfo, service_type_browsers, client->service_type_browsers, i);
613 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))) {
614 avahi_dbus_service_type_browser_free(i);
615 return avahi_dbus_respond_error(c, m, avahi_server_errno(avahi_server), NULL);
618 dbus_connection_register_object_path(c, i->path, &vtable, i);
619 return avahi_dbus_respond_path(c, m, i->path);
621 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "ServiceBrowserNew")) {
623 ServiceBrowserInfo *i;
624 static const DBusObjectPathVTable vtable = {
626 avahi_dbus_msg_service_browser_impl,
632 int32_t interface, protocol;
636 if (!dbus_message_get_args(
638 DBUS_TYPE_INT32, &interface,
639 DBUS_TYPE_INT32, &protocol,
640 DBUS_TYPE_STRING, &type,
641 DBUS_TYPE_STRING, &domain,
642 DBUS_TYPE_UINT32, &flags,
643 DBUS_TYPE_INVALID) || !type) {
644 avahi_log_warn("Error parsing Server::ServiceBrowserNew message");
648 if (!(client = client_get(dbus_message_get_sender(m), TRUE))) {
649 avahi_log_warn("Too many clients, client request failed.");
650 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_CLIENTS, NULL);
653 if (client->n_objects >= OBJECTS_PER_CLIENT_MAX) {
654 avahi_log_warn("Too many objects for client '%s', client request failed.", client->name);
655 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_OBJECTS, NULL);
661 i = avahi_new(ServiceBrowserInfo, 1);
662 i->id = ++client->current_id;
664 i->path = avahi_strdup_printf("/Client%u/ServiceBrowser%u", client->id, i->id);
665 AVAHI_LLIST_PREPEND(ServiceBrowserInfo, service_browsers, client->service_browsers, i);
668 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))) {
669 avahi_dbus_service_browser_free(i);
670 return avahi_dbus_respond_error(c, m, avahi_server_errno(avahi_server), NULL);
673 dbus_connection_register_object_path(c, i->path, &vtable, i);
674 return avahi_dbus_respond_path(c, m, i->path);
676 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "ResolveService")) {
678 int32_t interface, protocol, aprotocol;
680 char *name, *type, *domain;
681 SyncServiceResolverInfo *i;
683 if (!dbus_message_get_args(
685 DBUS_TYPE_INT32, &interface,
686 DBUS_TYPE_INT32, &protocol,
687 DBUS_TYPE_STRING, &name,
688 DBUS_TYPE_STRING, &type,
689 DBUS_TYPE_STRING, &domain,
690 DBUS_TYPE_INT32, &aprotocol,
691 DBUS_TYPE_UINT32, &flags,
692 DBUS_TYPE_INVALID) || !type) {
693 avahi_log_warn("Error parsing Server::ResolveService message");
697 if (!(client = client_get(dbus_message_get_sender(m), TRUE))) {
698 avahi_log_warn("Too many clients, client request failed.");
699 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_CLIENTS, NULL);
702 if (client->n_objects >= OBJECTS_PER_CLIENT_MAX) {
703 avahi_log_warn("Too many objects for client '%s', client request failed.", client->name);
704 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_OBJECTS, NULL);
713 i = avahi_new(SyncServiceResolverInfo, 1);
715 i->message = dbus_message_ref(m);
716 AVAHI_LLIST_PREPEND(SyncServiceResolverInfo, sync_service_resolvers, client->sync_service_resolvers, i);
719 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))) {
720 avahi_dbus_sync_service_resolver_free(i);
721 return avahi_dbus_respond_error(c, m, avahi_server_errno(avahi_server), NULL);
724 return DBUS_HANDLER_RESULT_HANDLED;
726 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "ServiceResolverNew")) {
728 int32_t interface, protocol, aprotocol;
730 char *name, *type, *domain;
731 AsyncServiceResolverInfo *i;
732 static const DBusObjectPathVTable vtable = {
734 avahi_dbus_msg_async_service_resolver_impl,
741 if (!dbus_message_get_args(
743 DBUS_TYPE_INT32, &interface,
744 DBUS_TYPE_INT32, &protocol,
745 DBUS_TYPE_STRING, &name,
746 DBUS_TYPE_STRING, &type,
747 DBUS_TYPE_STRING, &domain,
748 DBUS_TYPE_INT32, &aprotocol,
749 DBUS_TYPE_UINT32, &flags,
750 DBUS_TYPE_INVALID) || !type) {
751 avahi_log_warn("Error parsing Server::ServiceResolverNew message");
755 if (!(client = client_get(dbus_message_get_sender(m), TRUE))) {
756 avahi_log_warn(__FILE__": Too many clients, client request failed.");
757 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_CLIENTS, NULL);
760 if (client->n_objects >= OBJECTS_PER_CLIENT_MAX) {
761 avahi_log_warn(__FILE__": Too many objects for client '%s', client request failed.", client->name);
762 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_OBJECTS, NULL);
771 i = avahi_new(AsyncServiceResolverInfo, 1);
772 i->id = ++client->current_id;
774 i->path = avahi_strdup_printf("/Client%u/ServiceResolver%u", client->id, i->id);
775 AVAHI_LLIST_PREPEND(AsyncServiceResolverInfo, async_service_resolvers, client->async_service_resolvers, i);
778 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))) {
779 avahi_dbus_async_service_resolver_free(i);
780 return avahi_dbus_respond_error(c, m, avahi_server_errno(avahi_server), NULL);
783 /* avahi_log_debug(__FILE__": [%s], new service resolver for <%s.%s.%s>", i->path, name, type, domain); */
785 dbus_connection_register_object_path(c, i->path, &vtable, i);
786 return avahi_dbus_respond_path(c, m, i->path);
788 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "HostNameResolverNew")) {
790 int32_t interface, protocol, aprotocol;
793 AsyncHostNameResolverInfo *i;
794 static const DBusObjectPathVTable vtable = {
796 avahi_dbus_msg_async_host_name_resolver_impl,
803 if (!dbus_message_get_args(
805 DBUS_TYPE_INT32, &interface,
806 DBUS_TYPE_INT32, &protocol,
807 DBUS_TYPE_STRING, &name,
808 DBUS_TYPE_INT32, &aprotocol,
809 DBUS_TYPE_UINT32, &flags,
810 DBUS_TYPE_INVALID) || !name) {
811 avahi_log_warn("Error parsing Server::HostNameResolverNew message");
815 if (!(client = client_get(dbus_message_get_sender(m), TRUE))) {
816 avahi_log_warn(__FILE__": Too many clients, client request failed.");
817 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_CLIENTS, NULL);
820 if (client->n_objects >= OBJECTS_PER_CLIENT_MAX) {
821 avahi_log_warn(__FILE__": Too many objects for client '%s', client request failed.", client->name);
822 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_OBJECTS, NULL);
825 i = avahi_new(AsyncHostNameResolverInfo, 1);
826 i->id = ++client->current_id;
828 i->path = avahi_strdup_printf("/Client%u/HostNameResolver%u", client->id, i->id);
829 AVAHI_LLIST_PREPEND(AsyncHostNameResolverInfo, async_host_name_resolvers, client->async_host_name_resolvers, i);
832 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))) {
833 avahi_dbus_async_host_name_resolver_free(i);
834 return avahi_dbus_respond_error(c, m, avahi_server_errno(avahi_server), NULL);
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, "AddressResolverNew")) {
842 int32_t interface, protocol;
845 AsyncAddressResolverInfo *i;
847 static const DBusObjectPathVTable vtable = {
849 avahi_dbus_msg_async_address_resolver_impl,
856 if (!dbus_message_get_args(
858 DBUS_TYPE_INT32, &interface,
859 DBUS_TYPE_INT32, &protocol,
860 DBUS_TYPE_STRING, &address,
861 DBUS_TYPE_UINT32, &flags,
862 DBUS_TYPE_INVALID) || !address) {
863 avahi_log_warn("Error parsing Server::AddressResolverNew message");
867 if (!avahi_address_parse(address, AVAHI_PROTO_UNSPEC, &a))
868 return avahi_dbus_respond_error(c, m, AVAHI_ERR_INVALID_ADDRESS, NULL);
870 if (!(client = client_get(dbus_message_get_sender(m), TRUE))) {
871 avahi_log_warn(__FILE__": Too many clients, client request failed.");
872 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_CLIENTS, NULL);
875 if (client->n_objects >= OBJECTS_PER_CLIENT_MAX) {
876 avahi_log_warn(__FILE__": Too many objects for client '%s', client request failed.", client->name);
877 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_OBJECTS, NULL);
880 i = avahi_new(AsyncAddressResolverInfo, 1);
881 i->id = ++client->current_id;
883 i->path = avahi_strdup_printf("/Client%u/AddressResolver%u", client->id, i->id);
884 AVAHI_LLIST_PREPEND(AsyncAddressResolverInfo, async_address_resolvers, client->async_address_resolvers, i);
887 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))) {
888 avahi_dbus_async_address_resolver_free(i);
889 return avahi_dbus_respond_error(c, m, avahi_server_errno(avahi_server), NULL);
892 dbus_connection_register_object_path(c, i->path, &vtable, i);
893 return avahi_dbus_respond_path(c, m, i->path);
895 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "RecordBrowserNew")) {
897 RecordBrowserInfo *i;
898 static const DBusObjectPathVTable vtable = {
900 avahi_dbus_msg_record_browser_impl,
906 int32_t interface, protocol;
909 uint16_t type, clazz;
912 if (!dbus_message_get_args(
914 DBUS_TYPE_INT32, &interface,
915 DBUS_TYPE_INT32, &protocol,
916 DBUS_TYPE_STRING, &name,
917 DBUS_TYPE_UINT16, &clazz,
918 DBUS_TYPE_UINT16, &type,
919 DBUS_TYPE_UINT32, &flags,
920 DBUS_TYPE_INVALID) || !name) {
921 avahi_log_warn("Error parsing Server::RecordBrowserNew message");
925 if (!avahi_is_valid_domain_name(name))
926 return avahi_dbus_respond_error(c, m, AVAHI_ERR_INVALID_DOMAIN_NAME, NULL);
928 if (!(client = client_get(dbus_message_get_sender(m), TRUE))) {
929 avahi_log_warn("Too many clients, client request failed.");
930 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_CLIENTS, NULL);
933 if (client->n_objects >= OBJECTS_PER_CLIENT_MAX) {
934 avahi_log_warn("Too many objects for client '%s', client request failed.", client->name);
935 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_OBJECTS, NULL);
938 i = avahi_new(RecordBrowserInfo, 1);
939 i->id = ++client->current_id;
941 i->path = avahi_strdup_printf("/Client%u/RecordBrowser%u", client->id, i->id);
942 AVAHI_LLIST_PREPEND(RecordBrowserInfo, record_browsers, client->record_browsers, i);
945 key = avahi_key_new(name, clazz, type);
948 if (!(i->record_browser = avahi_s_record_browser_new(avahi_server, (AvahiIfIndex) interface, (AvahiProtocol) protocol, key, (AvahiLookupFlags) flags, avahi_dbus_record_browser_callback, i))) {
949 avahi_key_unref(key);
950 avahi_dbus_record_browser_free(i);
951 return avahi_dbus_respond_error(c, m, avahi_server_errno(avahi_server), NULL);
954 avahi_key_unref(key);
956 dbus_connection_register_object_path(c, i->path, &vtable, i);
957 return avahi_dbus_respond_path(c, m, i->path);
960 avahi_log_warn("Missed message %s::%s()", dbus_message_get_interface(m), dbus_message_get_member(m));
963 if (dbus_error_is_set(&error))
964 dbus_error_free(&error);
966 return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
969 void dbus_protocol_server_state_changed(AvahiServerState state) {
977 m = dbus_message_new_signal(AVAHI_DBUS_PATH_SERVER, AVAHI_DBUS_INTERFACE_SERVER, "StateChanged");
980 if (state == AVAHI_SERVER_COLLISION)
981 e = AVAHI_DBUS_ERR_COLLISION;
982 else if (state == AVAHI_SERVER_FAILURE)
983 e = avahi_error_number_to_dbus(avahi_server_errno(avahi_server));
985 e = AVAHI_DBUS_ERR_OK;
987 dbus_message_append_args(m, DBUS_TYPE_INT32, &t, DBUS_TYPE_STRING, &e, DBUS_TYPE_INVALID);
988 dbus_connection_send(server->bus, m, NULL);
989 dbus_message_unref(m);
992 int dbus_protocol_setup(const AvahiPoll *poll_api, int _disable_user_service_publishing) {
995 static const DBusObjectPathVTable server_vtable = {
1004 dbus_error_init(&error);
1006 disable_user_service_publishing = _disable_user_service_publishing;
1008 server = avahi_new(Server, 1);
1009 AVAHI_LLIST_HEAD_INIT(Clients, server->clients);
1010 server->current_id = 0;
1011 server->n_clients = 0;
1013 if (!(server->bus = dbus_bus_get(DBUS_BUS_SYSTEM, &error))) {
1014 assert(dbus_error_is_set(&error));
1015 avahi_log_error("dbus_bus_get(): %s", error.message);
1019 if (avahi_dbus_connection_glue(server->bus, poll_api) < 0) {
1020 avahi_log_error("avahi_dbus_connection_glue() failed");
1024 if (dbus_bus_request_name(server->bus, AVAHI_DBUS_NAME, DBUS_NAME_FLAG_PROHIBIT_REPLACEMENT, &error) != DBUS_REQUEST_NAME_REPLY_PRIMARY_OWNER) {
1025 if (dbus_error_is_set(&error)) {
1026 avahi_log_error("dbus_bus_request_name(): %s", error.message);
1030 avahi_log_error("Failed to acquire DBUS name '"AVAHI_DBUS_NAME"'");
1034 if (!(dbus_connection_add_filter(server->bus, msg_signal_filter_impl, (void*) poll_api, NULL))) {
1035 avahi_log_error("dbus_connection_add_filter() failed");
1039 dbus_bus_add_match(server->bus, "type='signal',""interface='" DBUS_INTERFACE_DBUS "'", &error);
1041 if (dbus_error_is_set(&error)) {
1042 avahi_log_error("dbus_bus_add_match(): %s", error.message);
1046 if (!(dbus_connection_register_object_path(server->bus, AVAHI_DBUS_PATH_SERVER, &server_vtable, NULL))) {
1047 avahi_log_error("dbus_connection_register_object_path() failed");
1055 dbus_connection_disconnect(server->bus);
1056 dbus_connection_unref(server->bus);
1059 if (dbus_error_is_set(&error))
1060 dbus_error_free(&error);
1067 void dbus_protocol_shutdown(void) {
1071 while (server->clients)
1072 client_free(server->clients);
1074 assert(server->n_clients == 0);
1077 dbus_connection_disconnect(server->bus);
1078 dbus_connection_unref(server->bus);