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);
159 static DBusHandlerResult msg_signal_filter_impl(AVAHI_GCC_UNUSED DBusConnection *c, DBusMessage *m, AVAHI_GCC_UNUSED void *userdata) {
162 dbus_error_init(&error);
164 /* avahi_log_debug(__FILE__": interface=%s, path=%s, member=%s", */
165 /* dbus_message_get_interface(m), */
166 /* dbus_message_get_path(m), */
167 /* dbus_message_get_member(m)); */
169 if (dbus_message_is_signal(m, DBUS_INTERFACE_LOCAL, "Disconnected")) {
170 /* No, we shouldn't quit, but until we get somewhere
171 * usefull such that we can restore our state, we will */
172 avahi_log_warn("Disconnnected from D-BUS, terminating...");
174 raise(SIGQUIT); /* The signal handler will catch this and terminate the process cleanly*/
176 return DBUS_HANDLER_RESULT_HANDLED;
178 } else if (dbus_message_is_signal(m, DBUS_INTERFACE_DBUS, "NameAcquired")) {
181 if (!dbus_message_get_args(m, &error, DBUS_TYPE_STRING, &name, DBUS_TYPE_INVALID)) {
182 avahi_log_warn("Error parsing NameAcquired message");
186 /* avahi_log_info(__FILE__": name acquired (%s)", name); */
187 return DBUS_HANDLER_RESULT_HANDLED;
189 } else if (dbus_message_is_signal(m, DBUS_INTERFACE_DBUS, "NameOwnerChanged")) {
190 char *name, *old, *new;
192 if (!dbus_message_get_args(m, &error, DBUS_TYPE_STRING, &name, DBUS_TYPE_STRING, &old, DBUS_TYPE_STRING, &new, DBUS_TYPE_INVALID)) {
193 avahi_log_warn("Error parsing NameOwnerChanged message");
200 if ((client = client_get(name, FALSE))) {
201 avahi_log_debug(__FILE__": client %s vanished.", name);
208 if (dbus_error_is_set(&error))
209 dbus_error_free(&error);
211 return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
214 static DBusHandlerResult msg_server_impl(DBusConnection *c, DBusMessage *m, AVAHI_GCC_UNUSED void *userdata) {
217 dbus_error_init(&error);
219 avahi_log_debug(__FILE__": interface=%s, path=%s, member=%s",
220 dbus_message_get_interface(m),
221 dbus_message_get_path(m),
222 dbus_message_get_member(m));
224 if (dbus_message_is_method_call(m, DBUS_INTERFACE_INTROSPECTABLE, "Introspect"))
225 return avahi_dbus_handle_introspect(c, m, "Server.introspect");
227 else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "GetHostName")) {
229 if (!dbus_message_get_args(m, &error, DBUS_TYPE_INVALID)) {
230 avahi_log_warn("Error parsing Server::GetHostName message");
234 return avahi_dbus_respond_string(c, m, avahi_server_get_host_name(avahi_server));
236 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "GetDomainName")) {
238 if (!dbus_message_get_args(m, &error, DBUS_TYPE_INVALID)) {
239 avahi_log_warn("Error parsing Server::GetDomainName message");
243 return avahi_dbus_respond_string(c, m, avahi_server_get_domain_name(avahi_server));
245 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "GetHostNameFqdn")) {
247 if (!(dbus_message_get_args(m, &error, DBUS_TYPE_INVALID))) {
248 avahi_log_warn("Error parsing Server::GetHostNameFqdn message");
252 return avahi_dbus_respond_string(c, m, avahi_server_get_host_name_fqdn(avahi_server));
254 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "IsNSSSupportAvailable")) {
255 if (!(dbus_message_get_args(m, &error, DBUS_TYPE_INVALID))) {
256 avahi_log_warn("Error parsing Server::IsNSSSupportAvailable message");
260 return avahi_dbus_respond_boolean(c, m, nss_support);
262 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "GetVersionString")) {
264 if (!(dbus_message_get_args(m, &error, DBUS_TYPE_INVALID))) {
265 avahi_log_warn("Error parsing Server::GetVersionString message");
269 return avahi_dbus_respond_string(c, m, PACKAGE_STRING);
271 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "GetAPIVersion")) {
273 if (!(dbus_message_get_args(m, &error, DBUS_TYPE_INVALID))) {
274 avahi_log_warn("Error parsing Server::GetAPIVersion message");
278 return avahi_dbus_respond_uint32(c, m, AVAHI_DBUS_API_VERSION);
280 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "GetState")) {
281 AvahiServerState state;
283 if (!(dbus_message_get_args(m, &error, DBUS_TYPE_INVALID))) {
284 avahi_log_warn("Error parsing Server::GetState message");
288 state = avahi_server_get_state(avahi_server);
289 return avahi_dbus_respond_int32(c, m, (int32_t) state);
291 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "GetLocalServiceCookie")) {
293 if (!(dbus_message_get_args(m, &error, DBUS_TYPE_INVALID))) {
294 avahi_log_warn("Error parsing Server::GetLocalServiceCookie message");
298 return avahi_dbus_respond_uint32(c, m, avahi_server_get_local_service_cookie(avahi_server));
300 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "GetNetworkInterfaceNameByIndex")) {
303 char name[IF_NAMESIZE];
306 if (!(dbus_message_get_args(m, &error, DBUS_TYPE_INT32, &idx, DBUS_TYPE_INVALID))) {
307 avahi_log_warn("Error parsing Server::GetNetworkInterfaceNameByIndex message");
311 #ifdef VALGRIND_WORKAROUND
312 return respond_string(c, m, "blah");
315 if ((fd = socket(AF_INET, SOCK_DGRAM, 0)) < 0)
316 if ((fd = socket(AF_INET6, SOCK_DGRAM, 0)) < 0) {
318 snprintf(txt, sizeof(txt), "OS Error: %s", strerror(errno));
319 return avahi_dbus_respond_error(c, m, AVAHI_ERR_OS, txt);
322 if ((!if_indextoname(idx, name))) {
324 snprintf(txt, sizeof(txt), "OS Error: %s", strerror(errno));
326 return avahi_dbus_respond_error(c, m, AVAHI_ERR_OS, txt);
331 return avahi_dbus_respond_string(c, m, name);
334 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "GetNetworkInterfaceIndexByName")) {
339 if (!(dbus_message_get_args(m, &error, DBUS_TYPE_STRING, &n, DBUS_TYPE_INVALID)) || !n) {
340 avahi_log_warn("Error parsing Server::GetNetworkInterfaceIndexByName message");
344 #ifdef VALGRIND_WORKAROUND
345 return respond_int32(c, m, 1);
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 (!(idx = if_nametoindex(n))) {
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_int32(c, m, idx);
366 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "GetAlternativeHostName")) {
369 if (!(dbus_message_get_args(m, &error, DBUS_TYPE_STRING, &n, DBUS_TYPE_INVALID)) || !n) {
370 avahi_log_warn("Error parsing Server::GetAlternativeHostName message");
374 t = avahi_alternative_host_name(n);
375 avahi_dbus_respond_string(c, m, t);
378 return DBUS_HANDLER_RESULT_HANDLED;
380 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "GetAlternativeServiceName")) {
383 if (!(dbus_message_get_args(m, &error, DBUS_TYPE_STRING, &n, DBUS_TYPE_INVALID)) || !n) {
384 avahi_log_warn("Error parsing Server::GetAlternativeServiceName message");
388 t = avahi_alternative_service_name(n);
389 avahi_dbus_respond_string(c, m, t);
392 return DBUS_HANDLER_RESULT_HANDLED;
394 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "EntryGroupNew")) {
397 static const DBusObjectPathVTable vtable = {
399 avahi_dbus_msg_entry_group_impl,
406 if (!dbus_message_get_args(m, &error, DBUS_TYPE_INVALID)) {
407 avahi_log_warn("Error parsing Server::EntryGroupNew message");
411 if (disable_user_service_publishing)
412 return avahi_dbus_respond_error(c, m, AVAHI_ERR_NOT_PERMITTED, NULL);
414 if (!(client = client_get(dbus_message_get_sender(m), TRUE))) {
415 avahi_log_warn("Too many clients, client request failed.");
416 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_CLIENTS, NULL);
419 if (client->n_objects >= OBJECTS_PER_CLIENT_MAX) {
420 avahi_log_warn("Too many objects for client '%s', client request failed.", client->name);
421 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_OBJECTS, NULL);
424 i = avahi_new(EntryGroupInfo, 1);
425 i->id = ++client->current_id;
427 i->path = avahi_strdup_printf("/Client%u/EntryGroup%u", client->id, i->id);
429 AVAHI_LLIST_PREPEND(EntryGroupInfo, entry_groups, client->entry_groups, i);
432 if (!(i->entry_group = avahi_s_entry_group_new(avahi_server, avahi_dbus_entry_group_callback, i))) {
433 avahi_dbus_entry_group_free(i);
434 return avahi_dbus_respond_error(c, m, avahi_server_errno(avahi_server), NULL);
437 dbus_connection_register_object_path(c, i->path, &vtable, i);
438 return avahi_dbus_respond_path(c, m, i->path);
440 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "ResolveHostName")) {
442 int32_t interface, protocol, aprotocol;
445 SyncHostNameResolverInfo *i;
447 if (!dbus_message_get_args(
449 DBUS_TYPE_INT32, &interface,
450 DBUS_TYPE_INT32, &protocol,
451 DBUS_TYPE_STRING, &name,
452 DBUS_TYPE_INT32, &aprotocol,
453 DBUS_TYPE_UINT32, &flags,
454 DBUS_TYPE_INVALID) || !name) {
455 avahi_log_warn("Error parsing Server::ResolveHostName message");
459 if (!(client = client_get(dbus_message_get_sender(m), TRUE))) {
460 avahi_log_warn("Too many clients, client request failed.");
461 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_CLIENTS, NULL);
464 if (client->n_objects >= OBJECTS_PER_CLIENT_MAX) {
465 avahi_log_warn("Too many objects for client '%s', client request failed.", client->name);
466 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_OBJECTS, NULL);
469 i = avahi_new(SyncHostNameResolverInfo, 1);
471 i->message = dbus_message_ref(m);
472 AVAHI_LLIST_PREPEND(SyncHostNameResolverInfo, sync_host_name_resolvers, client->sync_host_name_resolvers, i);
475 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))) {
476 avahi_dbus_sync_host_name_resolver_free(i);
477 return avahi_dbus_respond_error(c, m, avahi_server_errno(avahi_server), NULL);
480 return DBUS_HANDLER_RESULT_HANDLED;
482 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "ResolveAddress")) {
484 int32_t interface, protocol;
487 SyncAddressResolverInfo *i;
490 if (!dbus_message_get_args(
492 DBUS_TYPE_INT32, &interface,
493 DBUS_TYPE_INT32, &protocol,
494 DBUS_TYPE_STRING, &address,
495 DBUS_TYPE_UINT32, &flags,
496 DBUS_TYPE_INVALID) || !address) {
497 avahi_log_warn("Error parsing Server::ResolveAddress message");
501 if (!avahi_address_parse(address, AVAHI_PROTO_UNSPEC, &a))
502 return avahi_dbus_respond_error(c, m, AVAHI_ERR_INVALID_ADDRESS, NULL);
504 if (!(client = client_get(dbus_message_get_sender(m), TRUE))) {
505 avahi_log_warn("Too many clients, client request failed.");
506 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_CLIENTS, NULL);
509 if (client->n_objects >= OBJECTS_PER_CLIENT_MAX) {
510 avahi_log_warn("Too many objects for client '%s', client request failed.", client->name);
511 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_OBJECTS, NULL);
514 i = avahi_new(SyncAddressResolverInfo, 1);
516 i->message = dbus_message_ref(m);
517 AVAHI_LLIST_PREPEND(SyncAddressResolverInfo, sync_address_resolvers, client->sync_address_resolvers, i);
520 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))) {
521 avahi_dbus_sync_address_resolver_free(i);
522 return avahi_dbus_respond_error(c, m, avahi_server_errno(avahi_server), NULL);
525 return DBUS_HANDLER_RESULT_HANDLED;
527 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "DomainBrowserNew")) {
529 DomainBrowserInfo *i;
530 static const DBusObjectPathVTable vtable = {
532 avahi_dbus_msg_domain_browser_impl,
538 int32_t interface, protocol, type;
542 if (!dbus_message_get_args(
544 DBUS_TYPE_INT32, &interface,
545 DBUS_TYPE_INT32, &protocol,
546 DBUS_TYPE_STRING, &domain,
547 DBUS_TYPE_INT32, &type,
548 DBUS_TYPE_UINT32, &flags,
549 DBUS_TYPE_INVALID) || type < 0 || type >= AVAHI_DOMAIN_BROWSER_MAX) {
550 avahi_log_warn("Error parsing Server::DomainBrowserNew message");
554 if (!(client = client_get(dbus_message_get_sender(m), TRUE))) {
555 avahi_log_warn("Too many clients, client request failed.");
556 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_CLIENTS, NULL);
559 if (client->n_objects >= OBJECTS_PER_CLIENT_MAX) {
560 avahi_log_warn("Too many objects for client '%s', client request failed.", client->name);
561 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_OBJECTS, NULL);
567 i = avahi_new(DomainBrowserInfo, 1);
568 i->id = ++client->current_id;
570 i->path = avahi_strdup_printf("/Client%u/DomainBrowser%u", client->id, i->id);
571 AVAHI_LLIST_PREPEND(DomainBrowserInfo, domain_browsers, client->domain_browsers, i);
574 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))) {
575 avahi_dbus_domain_browser_free(i);
576 return avahi_dbus_respond_error(c, m, avahi_server_errno(avahi_server), NULL);
579 dbus_connection_register_object_path(c, i->path, &vtable, i);
580 return avahi_dbus_respond_path(c, m, i->path);
582 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "ServiceTypeBrowserNew")) {
584 ServiceTypeBrowserInfo *i;
585 static const DBusObjectPathVTable vtable = {
587 avahi_dbus_msg_service_type_browser_impl,
593 int32_t interface, protocol;
597 if (!dbus_message_get_args(
599 DBUS_TYPE_INT32, &interface,
600 DBUS_TYPE_INT32, &protocol,
601 DBUS_TYPE_STRING, &domain,
602 DBUS_TYPE_UINT32, &flags,
603 DBUS_TYPE_INVALID)) {
604 avahi_log_warn("Error parsing Server::ServiceTypeBrowserNew message");
608 if (!(client = client_get(dbus_message_get_sender(m), TRUE))) {
609 avahi_log_warn("Too many clients, client request failed.");
610 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_CLIENTS, NULL);
613 if (client->n_objects >= OBJECTS_PER_CLIENT_MAX) {
614 avahi_log_warn("Too many objects for client '%s', client request failed.", client->name);
615 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_OBJECTS, NULL);
621 i = avahi_new(ServiceTypeBrowserInfo, 1);
622 i->id = ++client->current_id;
624 i->path = avahi_strdup_printf("/Client%u/ServiceTypeBrowser%u", client->id, i->id);
625 AVAHI_LLIST_PREPEND(ServiceTypeBrowserInfo, service_type_browsers, client->service_type_browsers, i);
628 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))) {
629 avahi_dbus_service_type_browser_free(i);
630 return avahi_dbus_respond_error(c, m, avahi_server_errno(avahi_server), NULL);
633 dbus_connection_register_object_path(c, i->path, &vtable, i);
634 return avahi_dbus_respond_path(c, m, i->path);
636 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "ServiceBrowserNew")) {
638 ServiceBrowserInfo *i;
639 static const DBusObjectPathVTable vtable = {
641 avahi_dbus_msg_service_browser_impl,
647 int32_t interface, protocol;
651 if (!dbus_message_get_args(
653 DBUS_TYPE_INT32, &interface,
654 DBUS_TYPE_INT32, &protocol,
655 DBUS_TYPE_STRING, &type,
656 DBUS_TYPE_STRING, &domain,
657 DBUS_TYPE_UINT32, &flags,
658 DBUS_TYPE_INVALID) || !type) {
659 avahi_log_warn("Error parsing Server::ServiceBrowserNew message");
663 if (!(client = client_get(dbus_message_get_sender(m), TRUE))) {
664 avahi_log_warn("Too many clients, client request failed.");
665 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_CLIENTS, NULL);
668 if (client->n_objects >= OBJECTS_PER_CLIENT_MAX) {
669 avahi_log_warn("Too many objects for client '%s', client request failed.", client->name);
670 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_OBJECTS, NULL);
676 i = avahi_new(ServiceBrowserInfo, 1);
677 i->id = ++client->current_id;
679 i->path = avahi_strdup_printf("/Client%u/ServiceBrowser%u", client->id, i->id);
680 AVAHI_LLIST_PREPEND(ServiceBrowserInfo, service_browsers, client->service_browsers, i);
683 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))) {
684 avahi_dbus_service_browser_free(i);
685 return avahi_dbus_respond_error(c, m, avahi_server_errno(avahi_server), NULL);
688 dbus_connection_register_object_path(c, i->path, &vtable, i);
689 return avahi_dbus_respond_path(c, m, i->path);
691 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "ResolveService")) {
693 int32_t interface, protocol, aprotocol;
695 char *name, *type, *domain;
696 SyncServiceResolverInfo *i;
698 if (!dbus_message_get_args(
700 DBUS_TYPE_INT32, &interface,
701 DBUS_TYPE_INT32, &protocol,
702 DBUS_TYPE_STRING, &name,
703 DBUS_TYPE_STRING, &type,
704 DBUS_TYPE_STRING, &domain,
705 DBUS_TYPE_INT32, &aprotocol,
706 DBUS_TYPE_UINT32, &flags,
707 DBUS_TYPE_INVALID) || !type) {
708 avahi_log_warn("Error parsing Server::ResolveService message");
712 if (!(client = client_get(dbus_message_get_sender(m), TRUE))) {
713 avahi_log_warn("Too many clients, client request failed.");
714 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_CLIENTS, NULL);
717 if (client->n_objects >= OBJECTS_PER_CLIENT_MAX) {
718 avahi_log_warn("Too many objects for client '%s', client request failed.", client->name);
719 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_OBJECTS, NULL);
728 i = avahi_new(SyncServiceResolverInfo, 1);
730 i->message = dbus_message_ref(m);
731 AVAHI_LLIST_PREPEND(SyncServiceResolverInfo, sync_service_resolvers, client->sync_service_resolvers, i);
734 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))) {
735 avahi_dbus_sync_service_resolver_free(i);
736 return avahi_dbus_respond_error(c, m, avahi_server_errno(avahi_server), NULL);
739 return DBUS_HANDLER_RESULT_HANDLED;
741 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "ServiceResolverNew")) {
743 int32_t interface, protocol, aprotocol;
745 char *name, *type, *domain;
746 AsyncServiceResolverInfo *i;
747 static const DBusObjectPathVTable vtable = {
749 avahi_dbus_msg_async_service_resolver_impl,
756 if (!dbus_message_get_args(
758 DBUS_TYPE_INT32, &interface,
759 DBUS_TYPE_INT32, &protocol,
760 DBUS_TYPE_STRING, &name,
761 DBUS_TYPE_STRING, &type,
762 DBUS_TYPE_STRING, &domain,
763 DBUS_TYPE_INT32, &aprotocol,
764 DBUS_TYPE_UINT32, &flags,
765 DBUS_TYPE_INVALID) || !type) {
766 avahi_log_warn("Error parsing Server::ServiceResolverNew message");
770 if (!(client = client_get(dbus_message_get_sender(m), TRUE))) {
771 avahi_log_warn(__FILE__": Too many clients, client request failed.");
772 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_CLIENTS, NULL);
775 if (client->n_objects >= OBJECTS_PER_CLIENT_MAX) {
776 avahi_log_warn(__FILE__": Too many objects for client '%s', client request failed.", client->name);
777 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_OBJECTS, NULL);
786 i = avahi_new(AsyncServiceResolverInfo, 1);
787 i->id = ++client->current_id;
789 i->path = avahi_strdup_printf("/Client%u/ServiceResolver%u", client->id, i->id);
790 AVAHI_LLIST_PREPEND(AsyncServiceResolverInfo, async_service_resolvers, client->async_service_resolvers, i);
793 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))) {
794 avahi_dbus_async_service_resolver_free(i);
795 return avahi_dbus_respond_error(c, m, avahi_server_errno(avahi_server), NULL);
798 /* avahi_log_debug(__FILE__": [%s], new service resolver for <%s.%s.%s>", i->path, name, type, domain); */
800 dbus_connection_register_object_path(c, i->path, &vtable, i);
801 return avahi_dbus_respond_path(c, m, i->path);
803 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "HostNameResolverNew")) {
805 int32_t interface, protocol, aprotocol;
808 AsyncHostNameResolverInfo *i;
809 static const DBusObjectPathVTable vtable = {
811 avahi_dbus_msg_async_host_name_resolver_impl,
818 if (!dbus_message_get_args(
820 DBUS_TYPE_INT32, &interface,
821 DBUS_TYPE_INT32, &protocol,
822 DBUS_TYPE_STRING, &name,
823 DBUS_TYPE_INT32, &aprotocol,
824 DBUS_TYPE_UINT32, &flags,
825 DBUS_TYPE_INVALID) || !name) {
826 avahi_log_warn("Error parsing Server::HostNameResolverNew message");
830 if (!(client = client_get(dbus_message_get_sender(m), TRUE))) {
831 avahi_log_warn(__FILE__": Too many clients, client request failed.");
832 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_CLIENTS, NULL);
835 if (client->n_objects >= OBJECTS_PER_CLIENT_MAX) {
836 avahi_log_warn(__FILE__": Too many objects for client '%s', client request failed.", client->name);
837 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_OBJECTS, NULL);
840 i = avahi_new(AsyncHostNameResolverInfo, 1);
841 i->id = ++client->current_id;
843 i->path = avahi_strdup_printf("/Client%u/HostNameResolver%u", client->id, i->id);
844 AVAHI_LLIST_PREPEND(AsyncHostNameResolverInfo, async_host_name_resolvers, client->async_host_name_resolvers, i);
847 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))) {
848 avahi_dbus_async_host_name_resolver_free(i);
849 return avahi_dbus_respond_error(c, m, avahi_server_errno(avahi_server), NULL);
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, "AddressResolverNew")) {
857 int32_t interface, protocol;
860 AsyncAddressResolverInfo *i;
862 static const DBusObjectPathVTable vtable = {
864 avahi_dbus_msg_async_address_resolver_impl,
871 if (!dbus_message_get_args(
873 DBUS_TYPE_INT32, &interface,
874 DBUS_TYPE_INT32, &protocol,
875 DBUS_TYPE_STRING, &address,
876 DBUS_TYPE_UINT32, &flags,
877 DBUS_TYPE_INVALID) || !address) {
878 avahi_log_warn("Error parsing Server::AddressResolverNew message");
882 if (!avahi_address_parse(address, AVAHI_PROTO_UNSPEC, &a))
883 return avahi_dbus_respond_error(c, m, AVAHI_ERR_INVALID_ADDRESS, NULL);
885 if (!(client = client_get(dbus_message_get_sender(m), TRUE))) {
886 avahi_log_warn(__FILE__": Too many clients, client request failed.");
887 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_CLIENTS, NULL);
890 if (client->n_objects >= OBJECTS_PER_CLIENT_MAX) {
891 avahi_log_warn(__FILE__": Too many objects for client '%s', client request failed.", client->name);
892 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_OBJECTS, NULL);
895 i = avahi_new(AsyncAddressResolverInfo, 1);
896 i->id = ++client->current_id;
898 i->path = avahi_strdup_printf("/Client%u/AddressResolver%u", client->id, i->id);
899 AVAHI_LLIST_PREPEND(AsyncAddressResolverInfo, async_address_resolvers, client->async_address_resolvers, i);
902 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))) {
903 avahi_dbus_async_address_resolver_free(i);
904 return avahi_dbus_respond_error(c, m, avahi_server_errno(avahi_server), NULL);
907 dbus_connection_register_object_path(c, i->path, &vtable, i);
908 return avahi_dbus_respond_path(c, m, i->path);
910 } else if (dbus_message_is_method_call(m, AVAHI_DBUS_INTERFACE_SERVER, "RecordBrowserNew")) {
912 RecordBrowserInfo *i;
913 static const DBusObjectPathVTable vtable = {
915 avahi_dbus_msg_record_browser_impl,
921 int32_t interface, protocol;
924 uint16_t type, clazz;
927 if (!dbus_message_get_args(
929 DBUS_TYPE_INT32, &interface,
930 DBUS_TYPE_INT32, &protocol,
931 DBUS_TYPE_STRING, &name,
932 DBUS_TYPE_UINT16, &clazz,
933 DBUS_TYPE_UINT16, &type,
934 DBUS_TYPE_UINT32, &flags,
935 DBUS_TYPE_INVALID) || !name) {
936 avahi_log_warn("Error parsing Server::RecordBrowserNew message");
940 if (!avahi_is_valid_domain_name(name))
941 return avahi_dbus_respond_error(c, m, AVAHI_ERR_INVALID_DOMAIN_NAME, NULL);
943 if (!(client = client_get(dbus_message_get_sender(m), TRUE))) {
944 avahi_log_warn("Too many clients, client request failed.");
945 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_CLIENTS, NULL);
948 if (client->n_objects >= OBJECTS_PER_CLIENT_MAX) {
949 avahi_log_warn("Too many objects for client '%s', client request failed.", client->name);
950 return avahi_dbus_respond_error(c, m, AVAHI_ERR_TOO_MANY_OBJECTS, NULL);
953 i = avahi_new(RecordBrowserInfo, 1);
954 i->id = ++client->current_id;
956 i->path = avahi_strdup_printf("/Client%u/RecordBrowser%u", client->id, i->id);
957 AVAHI_LLIST_PREPEND(RecordBrowserInfo, record_browsers, client->record_browsers, i);
960 key = avahi_key_new(name, clazz, type);
963 if (!(i->record_browser = avahi_s_record_browser_new(avahi_server, (AvahiIfIndex) interface, (AvahiProtocol) protocol, key, (AvahiLookupFlags) flags, avahi_dbus_record_browser_callback, i))) {
964 avahi_key_unref(key);
965 avahi_dbus_record_browser_free(i);
966 return avahi_dbus_respond_error(c, m, avahi_server_errno(avahi_server), NULL);
969 avahi_key_unref(key);
971 dbus_connection_register_object_path(c, i->path, &vtable, i);
972 return avahi_dbus_respond_path(c, m, i->path);
975 avahi_log_warn("Missed message %s::%s()", dbus_message_get_interface(m), dbus_message_get_member(m));
978 if (dbus_error_is_set(&error))
979 dbus_error_free(&error);
981 return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
984 void dbus_protocol_server_state_changed(AvahiServerState state) {
992 m = dbus_message_new_signal(AVAHI_DBUS_PATH_SERVER, AVAHI_DBUS_INTERFACE_SERVER, "StateChanged");
995 if (state == AVAHI_SERVER_COLLISION)
996 e = AVAHI_DBUS_ERR_COLLISION;
997 else if (state == AVAHI_SERVER_FAILURE)
998 e = avahi_error_number_to_dbus(avahi_server_errno(avahi_server));
1000 e = AVAHI_DBUS_ERR_OK;
1002 dbus_message_append_args(m, DBUS_TYPE_INT32, &t, DBUS_TYPE_STRING, &e, DBUS_TYPE_INVALID);
1003 dbus_connection_send(server->bus, m, NULL);
1004 dbus_message_unref(m);
1007 int dbus_protocol_setup(const AvahiPoll *poll_api, int _disable_user_service_publishing) {
1010 static const DBusObjectPathVTable server_vtable = {
1019 dbus_error_init(&error);
1021 disable_user_service_publishing = _disable_user_service_publishing;
1023 server = avahi_new(Server, 1);
1024 AVAHI_LLIST_HEAD_INIT(Clients, server->clients);
1025 server->current_id = 0;
1026 server->n_clients = 0;
1028 if (!(server->bus = dbus_bus_get(DBUS_BUS_SYSTEM, &error))) {
1029 assert(dbus_error_is_set(&error));
1030 avahi_log_error("dbus_bus_get(): %s", error.message);
1034 if (avahi_dbus_connection_glue(server->bus, poll_api) < 0) {
1035 avahi_log_error("avahi_dbus_connection_glue() failed");
1039 if (dbus_bus_request_name(
1042 #if (DBUS_VERSION_MAJOR == 0) && (DBUS_VERSION_MINOR >= 60)
1043 DBUS_NAME_FLAG_DO_NOT_QUEUE,
1045 DBUS_NAME_FLAG_PROHIBIT_REPLACEMENT,
1047 &error) != DBUS_REQUEST_NAME_REPLY_PRIMARY_OWNER) {
1048 if (dbus_error_is_set(&error)) {
1049 avahi_log_error("dbus_bus_request_name(): %s", error.message);
1053 avahi_log_error("Failed to acquire DBUS name '"AVAHI_DBUS_NAME"'");
1057 if (!(dbus_connection_add_filter(server->bus, msg_signal_filter_impl, (void*) poll_api, NULL))) {
1058 avahi_log_error("dbus_connection_add_filter() failed");
1062 dbus_bus_add_match(server->bus, "type='signal',""interface='" DBUS_INTERFACE_DBUS "'", &error);
1064 if (dbus_error_is_set(&error)) {
1065 avahi_log_error("dbus_bus_add_match(): %s", error.message);
1069 if (!(dbus_connection_register_object_path(server->bus, AVAHI_DBUS_PATH_SERVER, &server_vtable, NULL))) {
1070 avahi_log_error("dbus_connection_register_object_path() failed");
1078 dbus_connection_disconnect(server->bus);
1079 dbus_connection_unref(server->bus);
1082 if (dbus_error_is_set(&error))
1083 dbus_error_free(&error);
1090 void dbus_protocol_shutdown(void) {
1094 while (server->clients)
1095 client_free(server->clients);
1097 assert(server->n_clients == 0);
1100 dbus_connection_disconnect(server->bus);
1101 dbus_connection_unref(server->bus);