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
30 #include <dbus/dbus.h>
32 #include <avahi-client/client.h>
33 #include <avahi-common/dbus.h>
34 #include <avahi-common/llist.h>
35 #include <avahi-common/error.h>
36 #include <avahi-common/malloc.h>
41 AvahiDomainBrowser* avahi_domain_browser_new(
43 AvahiIfIndex interface,
44 AvahiProtocol protocol,
46 AvahiDomainBrowserType btype,
47 AvahiLookupFlags flags,
48 AvahiDomainBrowserCallback callback,
51 AvahiDomainBrowser *db = NULL;
52 DBusMessage *message = NULL, *reply = NULL;
55 int32_t i_interface, i_protocol, i_flags, bt;
60 dbus_error_init (&error);
62 if (client->state == AVAHI_CLIENT_DISCONNECTED) {
63 avahi_client_set_errno(client, AVAHI_ERR_BAD_STATE);
70 if (!(db = avahi_new (AvahiDomainBrowser, 1))) {
71 avahi_client_set_errno(client, AVAHI_ERR_NO_MEMORY);
76 db->callback = callback;
77 db->userdata = userdata;
80 AVAHI_LLIST_PREPEND(AvahiDomainBrowser, domain_browsers, client->domain_browsers, db);
82 if (!(message = dbus_message_new_method_call (AVAHI_DBUS_NAME, AVAHI_DBUS_PATH_SERVER, AVAHI_DBUS_INTERFACE_SERVER, "DomainBrowserNew"))) {
83 avahi_client_set_errno(client, AVAHI_ERR_NO_MEMORY);
87 i_interface = (int32_t) interface;
88 i_protocol = (int32_t) protocol;
89 i_flags = (int32_t) flags;
92 if (!(dbus_message_append_args(
94 DBUS_TYPE_INT32, &i_interface,
95 DBUS_TYPE_INT32, &i_protocol,
96 DBUS_TYPE_STRING, &domain,
98 DBUS_TYPE_INT32, &flags,
99 DBUS_TYPE_INVALID))) {
100 avahi_client_set_errno(client, AVAHI_ERR_NO_MEMORY);
104 if (!(reply = dbus_connection_send_with_reply_and_block (client->bus, message, -1, &error)) ||
105 dbus_error_is_set(&error)) {
106 avahi_client_set_errno(client, AVAHI_ERR_DBUS_ERROR);
110 if (!dbus_message_get_args (reply, &error, DBUS_TYPE_OBJECT_PATH, &path, DBUS_TYPE_INVALID) ||
111 dbus_error_is_set(&error) ||
113 avahi_client_set_errno(client, AVAHI_ERR_DBUS_ERROR);
117 if (!(db->path = avahi_strdup(path))) {
119 /* FIXME: We don't remove the object on the server side */
121 avahi_client_set_errno(client, AVAHI_ERR_NO_MEMORY);
125 dbus_message_unref(message);
126 dbus_message_unref(reply);
132 if (dbus_error_is_set(&error)) {
133 avahi_client_set_dbus_error(client, &error);
134 dbus_error_free(&error);
138 avahi_domain_browser_free(db);
141 dbus_message_unref(message);
144 dbus_message_unref(reply);
149 AvahiClient* avahi_domain_browser_get_client (AvahiDomainBrowser *b)
155 int avahi_domain_browser_free (AvahiDomainBrowser *b) {
162 if (b->path && client->state != AVAHI_CLIENT_DISCONNECTED)
163 r = avahi_client_simple_method_call(client, b->path, AVAHI_DBUS_INTERFACE_DOMAIN_BROWSER, "Free");
165 AVAHI_LLIST_REMOVE(AvahiDomainBrowser, domain_browsers, client->domain_browsers, b);
173 DBusHandlerResult avahi_domain_browser_event (AvahiClient *client, AvahiBrowserEvent event, DBusMessage *message) {
174 AvahiDomainBrowser *db = NULL;
178 int32_t interface = AVAHI_IF_UNSPEC, protocol = AVAHI_PROTO_UNSPEC, flags = 0;
183 dbus_error_init (&error);
185 if (!(path = dbus_message_get_path(message)))
188 for (db = client->domain_browsers; db; db = db->domain_browsers_next)
189 if (strcmp (db->path, path) == 0)
195 if (event == AVAHI_BROWSER_NEW || event == AVAHI_BROWSER_REMOVE) {
196 if (!dbus_message_get_args(
198 DBUS_TYPE_INT32, &interface,
199 DBUS_TYPE_INT32, &protocol,
200 DBUS_TYPE_STRING, &domain,
201 DBUS_TYPE_INT32, &flags,
202 DBUS_TYPE_INVALID) ||
203 dbus_error_is_set (&error)) {
204 fprintf(stderr, "Failed to parse browser event.\n");
209 db->callback(db, (AvahiIfIndex) interface, (AvahiProtocol) protocol, event, domain, (AvahiLookupResultFlags) flags, db->userdata);
211 return DBUS_HANDLER_RESULT_HANDLED;
214 dbus_error_free (&error);
215 return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
218 /* AvahiServiceTypeBrowser */
219 AvahiServiceTypeBrowser* avahi_service_type_browser_new(
221 AvahiIfIndex interface,
222 AvahiProtocol protocol,
224 AvahiLookupFlags flags,
225 AvahiServiceTypeBrowserCallback callback,
228 AvahiServiceTypeBrowser *b = NULL;
229 DBusMessage *message = NULL, *reply = NULL;
232 int32_t i_interface, i_protocol, i_flags;
237 dbus_error_init(&error);
239 if (client->state == AVAHI_CLIENT_DISCONNECTED) {
240 avahi_client_set_errno(client, AVAHI_ERR_BAD_STATE);
247 if (!(b = avahi_new(AvahiServiceTypeBrowser, 1))) {
248 avahi_client_set_errno(client, AVAHI_ERR_NO_MEMORY);
253 b->callback = callback;
254 b->userdata = userdata;
257 AVAHI_LLIST_PREPEND(AvahiServiceTypeBrowser, service_type_browsers, client->service_type_browsers, b);
259 if (!(message = dbus_message_new_method_call (AVAHI_DBUS_NAME, AVAHI_DBUS_PATH_SERVER, AVAHI_DBUS_INTERFACE_SERVER, "ServiceTypeBrowserNew"))) {
260 avahi_client_set_errno(client, AVAHI_ERR_NO_MEMORY);
264 i_interface = (int32_t) interface;
265 i_protocol = (int32_t) protocol;
266 i_flags = (int32_t) flags;
268 if (!dbus_message_append_args(
270 DBUS_TYPE_INT32, &i_interface,
271 DBUS_TYPE_INT32, &i_protocol,
272 DBUS_TYPE_STRING, &domain,
273 DBUS_TYPE_INT32, &i_flags,
274 DBUS_TYPE_INVALID)) {
275 avahi_client_set_errno(client, AVAHI_ERR_NO_MEMORY);
279 if (!(reply = dbus_connection_send_with_reply_and_block (client->bus, message, -1, &error)) ||
280 dbus_error_is_set(&error)) {
281 avahi_client_set_errno(client, AVAHI_ERR_DBUS_ERROR);
285 if (!dbus_message_get_args (reply, &error, DBUS_TYPE_OBJECT_PATH, &path, DBUS_TYPE_INVALID) ||
286 dbus_error_is_set(&error) ||
288 avahi_client_set_errno(client, AVAHI_ERR_DBUS_ERROR);
292 if (!(b->path = avahi_strdup(path))) {
294 /* FIXME: We don't remove the object on the server side */
296 avahi_client_set_errno(client, AVAHI_ERR_NO_MEMORY);
300 dbus_message_unref(message);
301 dbus_message_unref(reply);
307 if (dbus_error_is_set(&error)) {
308 avahi_client_set_dbus_error(client, &error);
309 dbus_error_free(&error);
313 avahi_service_type_browser_free(b);
316 dbus_message_unref(message);
319 dbus_message_unref(reply);
324 AvahiClient* avahi_service_type_browser_get_client (AvahiServiceTypeBrowser *b)
330 int avahi_service_type_browser_free (AvahiServiceTypeBrowser *b) {
337 if (b->path && client->state != AVAHI_CLIENT_DISCONNECTED)
338 r = avahi_client_simple_method_call(client, b->path, AVAHI_DBUS_INTERFACE_SERVICE_TYPE_BROWSER, "Free");
340 AVAHI_LLIST_REMOVE(AvahiServiceTypeBrowser, service_type_browsers, b->client->service_type_browsers, b);
347 DBusHandlerResult avahi_service_type_browser_event (AvahiClient *client, AvahiBrowserEvent event, DBusMessage *message) {
348 AvahiServiceTypeBrowser *b = NULL;
351 char *domain = NULL, *type = NULL;
352 int32_t interface = AVAHI_IF_UNSPEC, protocol = AVAHI_PROTO_UNSPEC, flags = 0;
357 dbus_error_init (&error);
359 if (!(path = dbus_message_get_path(message)))
362 for (b = client->service_type_browsers; b; b = b->service_type_browsers_next)
363 if (strcmp (b->path, path) == 0)
369 if (event == AVAHI_BROWSER_NEW || event == AVAHI_BROWSER_REMOVE) {
370 if (!dbus_message_get_args(
372 DBUS_TYPE_INT32, &interface,
373 DBUS_TYPE_INT32, &protocol,
374 DBUS_TYPE_STRING, &type,
375 DBUS_TYPE_STRING, &domain,
376 DBUS_TYPE_INT32, &flags,
377 DBUS_TYPE_INVALID) ||
378 dbus_error_is_set(&error)) {
379 fprintf(stderr, "Failed to parse browser event.\n");
384 b->callback(b, (AvahiIfIndex) interface, (AvahiProtocol) protocol, event, type, domain, (AvahiLookupResultFlags) flags, b->userdata);
386 return DBUS_HANDLER_RESULT_HANDLED;
389 dbus_error_free (&error);
390 return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
393 /* AvahiServiceBrowser */
395 AvahiServiceBrowser* avahi_service_browser_new(
397 AvahiIfIndex interface,
398 AvahiProtocol protocol,
401 AvahiLookupFlags flags,
402 AvahiServiceBrowserCallback callback,
405 AvahiServiceBrowser *b = NULL;
406 DBusMessage *message = NULL, *reply = NULL;
409 int32_t i_protocol, i_interface, i_flags;
415 dbus_error_init(&error);
417 if (client->state == AVAHI_CLIENT_DISCONNECTED) {
418 avahi_client_set_errno(client, AVAHI_ERR_BAD_STATE);
425 if (!(b = avahi_new(AvahiServiceBrowser, 1))) {
426 avahi_client_set_errno(client, AVAHI_ERR_NO_MEMORY);
431 b->callback = callback;
432 b->userdata = userdata;
435 AVAHI_LLIST_PREPEND(AvahiServiceBrowser, service_browsers, client->service_browsers, b);
437 if (!(message = dbus_message_new_method_call (AVAHI_DBUS_NAME, AVAHI_DBUS_PATH_SERVER, AVAHI_DBUS_INTERFACE_SERVER, "ServiceBrowserNew"))) {
438 avahi_client_set_errno(client, AVAHI_ERR_NO_MEMORY);
442 i_interface = (int32_t) interface;
443 i_protocol = (int32_t) protocol;
444 i_flags = (int32_t) flags;
446 if (!dbus_message_append_args(
448 DBUS_TYPE_INT32, &i_interface,
449 DBUS_TYPE_INT32, &i_protocol,
450 DBUS_TYPE_STRING, &type,
451 DBUS_TYPE_STRING, &domain,
452 DBUS_TYPE_INT32, &i_flags,
453 DBUS_TYPE_INVALID)) {
454 avahi_client_set_errno(client, AVAHI_ERR_NO_MEMORY);
458 if (!(reply = dbus_connection_send_with_reply_and_block (client->bus, message, -1, &error)) ||
459 dbus_error_is_set(&error)) {
460 avahi_client_set_errno(client, AVAHI_ERR_DBUS_ERROR);
464 if (!dbus_message_get_args (reply, &error, DBUS_TYPE_OBJECT_PATH, &path, DBUS_TYPE_INVALID) ||
465 dbus_error_is_set(&error) ||
467 avahi_client_set_errno(client, AVAHI_ERR_DBUS_ERROR);
471 if (!(b->path = avahi_strdup(path))) {
473 /* FIXME: We don't remove the object on the server side */
475 avahi_client_set_errno(client, AVAHI_ERR_NO_MEMORY);
479 dbus_message_unref(message);
480 dbus_message_unref(reply);
485 if (dbus_error_is_set(&error)) {
486 avahi_client_set_dbus_error(client, &error);
487 dbus_error_free(&error);
491 avahi_service_browser_free(b);
494 dbus_message_unref(message);
497 dbus_message_unref(reply);
502 AvahiClient* avahi_service_browser_get_client (AvahiServiceBrowser *b)
508 int avahi_service_browser_free (AvahiServiceBrowser *b) {
515 if (b->path && client->state != AVAHI_CLIENT_DISCONNECTED)
516 r = avahi_client_simple_method_call(client, b->path, AVAHI_DBUS_INTERFACE_SERVICE_BROWSER, "Free");
518 AVAHI_LLIST_REMOVE(AvahiServiceBrowser, service_browsers, b->client->service_browsers, b);
526 DBusHandlerResult avahi_service_browser_event (AvahiClient *client, AvahiBrowserEvent event, DBusMessage *message) {
527 AvahiServiceBrowser *b = NULL;
530 char *name = NULL, *type = NULL, *domain = NULL;
531 int32_t interface = AVAHI_IF_UNSPEC, protocol = AVAHI_PROTO_UNSPEC, flags = 0;
533 dbus_error_init (&error);
535 if (!(path = dbus_message_get_path(message)))
538 for (b = client->service_browsers; b; b = b->service_browsers_next)
539 if (strcmp (b->path, path) == 0)
545 if (event == AVAHI_BROWSER_NEW || event == AVAHI_BROWSER_REMOVE) {
546 if (!dbus_message_get_args (
548 DBUS_TYPE_INT32, &interface,
549 DBUS_TYPE_INT32, &protocol,
550 DBUS_TYPE_STRING, &name,
551 DBUS_TYPE_STRING, &type,
552 DBUS_TYPE_STRING, &domain,
553 DBUS_TYPE_INT32, &flags,
554 DBUS_TYPE_INVALID) ||
555 dbus_error_is_set(&error)) {
556 fprintf(stderr, "Failed to parse browser event.\n");
561 b->callback(b, (AvahiIfIndex) interface, (AvahiProtocol) protocol, event, name, type, domain, (AvahiLookupResultFlags) flags, b->userdata);
563 return DBUS_HANDLER_RESULT_HANDLED;
566 dbus_error_free (&error);
567 return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;