X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;f=avahi-client%2Fbrowser.c;h=34a36015b45076f080974fbba4209a597493a6a9;hb=a51806cb5a410c6dde06c06263733a8b04fce061;hp=6e0ed5d364bc6200f39e09d8f21fe907bd586c35;hpb=77dc1cb05c8e6d23bd9cea37d4b4644cd76f0f82;p=catta

diff --git a/avahi-client/browser.c b/avahi-client/browser.c
index 6e0ed5d..34a3601 100644
--- a/avahi-client/browser.c
+++ b/avahi-client/browser.c
@@ -23,390 +23,529 @@
 #include <config.h>
 #endif
 
-#include <avahi-client/client.h>
-#include <avahi-common/dbus.h>
-#include <avahi-common/llist.h>
-#include <avahi-common/error.h>
 #include <stdlib.h>
 #include <stdio.h>
 #include <string.h>
 
-#define DBUS_API_SUBJECT_TO_CHANGE
 #include <dbus/dbus.h>
-#include <dbus/dbus-glib-lowlevel.h>
 
-#include <stdlib.h>
+#include <avahi-client/client.h>
+#include <avahi-common/dbus.h>
+#include <avahi-common/llist.h>
+#include <avahi-common/error.h>
+#include <avahi-common/malloc.h>
 
 #include "client.h"
 #include "internal.h"
 
-/* AvahiDomainBrowser */
-
-AvahiDomainBrowser* avahi_domain_browser_new (AvahiClient *client, AvahiIfIndex interface, AvahiProtocol protocol, char *domain, AvahiDomainBrowserType btype, AvahiDomainBrowserCallback callback, void *user_data)
-{
-    AvahiDomainBrowser *tmp = NULL;
-    DBusMessage *message = NULL, *reply;
+AvahiDomainBrowser* avahi_domain_browser_new(
+    AvahiClient *client,
+    AvahiIfIndex interface,
+    AvahiProtocol protocol,
+    const char *domain,
+    AvahiDomainBrowserType btype,
+    AvahiDomainBrowserCallback callback,
+    void *userdata) {
+    
+    AvahiDomainBrowser *db = NULL;
+    DBusMessage *message = NULL, *reply = NULL;
     DBusError error;
     char *path;
+    int32_t i_interface, i_protocol, bt;
 
-    if (client == NULL)
-        return NULL;
+    assert(client);
+    assert(callback);
 
     dbus_error_init (&error);
 
-    message = dbus_message_new_method_call (AVAHI_DBUS_NAME, AVAHI_DBUS_PATH_SERVER,
-            AVAHI_DBUS_INTERFACE_SERVER, "DomainBrowserNew");
+    if (client->state == AVAHI_CLIENT_DISCONNECTED) {
+        avahi_client_set_errno(client, AVAHI_ERR_BAD_STATE);
+        goto fail;
+    }
 
-    if (!dbus_message_append_args (message, DBUS_TYPE_INT32, &interface, DBUS_TYPE_INT32, &protocol, DBUS_TYPE_STRING, &domain, DBUS_TYPE_INT32, &btype, DBUS_TYPE_INVALID))
-        goto dbus_error;
+    if (!domain)
+        domain = "";
 
-    reply = dbus_connection_send_with_reply_and_block (client->bus, message, -1, &error);
+    if (!(db = avahi_new (AvahiDomainBrowser, 1))) {
+        avahi_client_set_errno(client, AVAHI_ERR_NO_MEMORY);
+        goto fail;
+    }
 
-    if (dbus_error_is_set (&error) || reply == NULL)
-        goto dbus_error;
+    db->client = client;
+    db->callback = callback;
+    db->userdata = userdata;
+    db->path = NULL;
 
-    if (!dbus_message_get_args (reply, &error, DBUS_TYPE_OBJECT_PATH, &path, DBUS_TYPE_INVALID))
-        goto dbus_error;
+    AVAHI_LLIST_PREPEND(AvahiDomainBrowser, domain_browsers, client->domain_browsers, db);
 
-    if (dbus_error_is_set (&error) || path == NULL)
-        goto dbus_error;
+    if (!(message = dbus_message_new_method_call (AVAHI_DBUS_NAME, AVAHI_DBUS_PATH_SERVER, AVAHI_DBUS_INTERFACE_SERVER, "DomainBrowserNew"))) {
+        avahi_client_set_errno(client, AVAHI_ERR_NO_MEMORY);
+        goto fail;
+    }
 
-    tmp = malloc (sizeof (AvahiDomainBrowser));
-    tmp->client = client;
-    tmp->callback = callback;
-    tmp->user_data = user_data;
-    tmp->path = strdup (path);
+    i_interface = interface;
+    i_protocol = protocol;
+    bt = btype;
+
+    if (!(dbus_message_append_args(
+              message,
+              DBUS_TYPE_INT32, &i_interface,
+              DBUS_TYPE_INT32, &i_protocol,
+              DBUS_TYPE_STRING, &domain,
+              DBUS_TYPE_INT32, &bt,
+              DBUS_TYPE_INVALID))) {
+        avahi_client_set_errno(client, AVAHI_ERR_NO_MEMORY);
+        goto fail;
+    }
 
-    AVAHI_LLIST_PREPEND(AvahiDomainBrowser, domain_browsers, client->domain_browsers, tmp);
+    if (!(reply = dbus_connection_send_with_reply_and_block (client->bus, message, -1, &error)) ||
+        dbus_error_is_set(&error)) {
+        avahi_client_set_errno(client, AVAHI_ERR_DBUS_ERROR);
+        goto fail;
+    }
 
-    return tmp;
+    if (!dbus_message_get_args (reply, &error, DBUS_TYPE_OBJECT_PATH, &path, DBUS_TYPE_INVALID) ||
+        dbus_error_is_set(&error) ||
+        !path) {
+        avahi_client_set_errno(client, AVAHI_ERR_DBUS_ERROR);
+        goto fail;
+    }
 
-dbus_error:
-    dbus_error_free (&error);
-    avahi_client_set_errno (client, AVAHI_ERR_DBUS_ERROR);
+    if (!(db->path = avahi_strdup(path))) {
 
-    return NULL;
-}
+        /* FIXME: We don't remove the object on the server side */
 
-void
-avahi_domain_browser_free (AvahiDomainBrowser *b)
-{
-    DBusMessage *message = NULL;
+        avahi_client_set_errno(client, AVAHI_ERR_NO_MEMORY);
+        goto fail;
+    }
 
-    if (b == NULL || b->path == NULL)
-        return;
+    dbus_message_unref(message);
+    dbus_message_unref(reply);
+    
+    return db;
 
-    message = dbus_message_new_method_call (AVAHI_DBUS_NAME,
-            b->path,
-            AVAHI_DBUS_INTERFACE_DOMAIN_BROWSER, "Free");
+fail:
 
-    dbus_connection_send (b->client->bus, message, NULL);
+    if (dbus_error_is_set(&error)) {
+        avahi_client_set_dbus_error(client, &error);
+        dbus_error_free(&error);
+    }
 
-    AVAHI_LLIST_REMOVE(AvahiDomainBrowser, domain_browsers, b->client->domain_browsers, b);
+    if (db)
+        avahi_domain_browser_free(db);
+    
+    if (message)
+        dbus_message_unref(message);
 
-    free (b);
+    if (reply)
+        dbus_message_unref(reply);
 
-    return;
+    return NULL;
 }
 
-char*
-avahi_domain_browser_path (AvahiDomainBrowser *b)
+AvahiClient* avahi_domain_browser_get_client (AvahiDomainBrowser *b)
 {
-    return b->path;
+    assert(b);
+    return b->client;
 }
 
-DBusHandlerResult
-avahi_domain_browser_event (AvahiClient *client, AvahiBrowserEvent event, DBusMessage *message)
-{
-    AvahiDomainBrowser *n, *db = NULL;
+int avahi_domain_browser_free (AvahiDomainBrowser *b) {
+    AvahiClient *client;
+    int r = AVAHI_OK;
+
+    assert(b);
+    client = b->client;
+
+    if (b->path && client->state != AVAHI_CLIENT_DISCONNECTED)
+        r = avahi_client_simple_method_call(client, b->path, AVAHI_DBUS_INTERFACE_DOMAIN_BROWSER, "Free");
+
+    AVAHI_LLIST_REMOVE(AvahiDomainBrowser, domain_browsers, client->domain_browsers, b);
+
+    avahi_free(b->path);
+    avahi_free(b);
+
+    return r;
+}
+
+DBusHandlerResult avahi_domain_browser_event (AvahiClient *client, AvahiBrowserEvent event, DBusMessage *message) {
+    AvahiDomainBrowser *db = NULL;
     DBusError error;
     const char *path;
     char *domain;
-    int interface, protocol;
+    int32_t interface, protocol;
 
+    assert(client);
+    assert(message);
+    
     dbus_error_init (&error);
 
-    path = dbus_message_get_path (message);
-
-    if (path == NULL)
-        goto out;
+    if (!(path = dbus_message_get_path(message)))
+        goto fail;
 
-    for (n = client->domain_browsers; n != NULL; n = n->domain_browsers_next)
-    {
-        printf ("cmp: %s, %s\n", n->path, path);
-        if (strcmp (n->path, path) == 0) {
-            db = n;
+    for (db = client->domain_browsers; db; db = db->domain_browsers_next)
+        if (strcmp (db->path, path) == 0)
             break;
-        }
-    }
-
-    if (db == NULL)
-        goto out;
 
-    dbus_message_get_args (message, &error, DBUS_TYPE_INT32, &interface,
-            DBUS_TYPE_INT32, &protocol, DBUS_TYPE_STRING, &domain, DBUS_TYPE_INVALID);
-
-    if (dbus_error_is_set (&error))
-        goto out;
+    if (!db)
+        goto fail;
+
+    if (!dbus_message_get_args(
+              message, &error,
+              DBUS_TYPE_INT32, &interface,
+              DBUS_TYPE_INT32, &protocol,
+              DBUS_TYPE_STRING, &domain,
+              DBUS_TYPE_INVALID) ||
+          dbus_error_is_set (&error)) {
+        fprintf(stderr, "Failed to parse browser event.\n");
+        goto fail;
+    }
 
-    db->callback (db, interface, protocol, event, domain, db->user_data);
+    db->callback(db, (AvahiIfIndex) interface, (AvahiProtocol) protocol, event, domain, db->userdata);
 
     return DBUS_HANDLER_RESULT_HANDLED;
 
-out:
+fail:
     dbus_error_free (&error);
     return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
 }
 
 /* AvahiServiceTypeBrowser */
-AvahiServiceTypeBrowser* avahi_service_type_browser_new (AvahiClient *client, AvahiIfIndex interface, AvahiProtocol protocol, char *domain, AvahiServiceTypeBrowserCallback callback, void *user_data)
-{
-    AvahiServiceTypeBrowser *tmp = NULL;
-    DBusMessage *message = NULL, *reply;
+AvahiServiceTypeBrowser* avahi_service_type_browser_new(
+    AvahiClient *client,
+    AvahiIfIndex interface,
+    AvahiProtocol protocol,
+    const char *domain,
+    AvahiServiceTypeBrowserCallback callback,
+    void *userdata) {
+        
+    AvahiServiceTypeBrowser *b = NULL;
+    DBusMessage *message = NULL, *reply = NULL;
     DBusError error;
     char *path;
+    int32_t i_interface, i_protocol;
 
-    if (client == NULL)
-        return NULL;
+    assert(client);
+    assert(callback);
 
-    dbus_error_init (&error);
+    dbus_error_init(&error);
 
-    message = dbus_message_new_method_call (AVAHI_DBUS_NAME,
-            AVAHI_DBUS_PATH_SERVER,
-            AVAHI_DBUS_INTERFACE_SERVER,
-            "ServiceTypeBrowserNew");
+    if (client->state == AVAHI_CLIENT_DISCONNECTED) {
+        avahi_client_set_errno(client, AVAHI_ERR_BAD_STATE);
+        goto fail;
+    }
 
-    if (!dbus_message_append_args (message, DBUS_TYPE_INT32, &interface, DBUS_TYPE_INT32, &protocol, DBUS_TYPE_STRING, &domain, DBUS_TYPE_INVALID))
-        goto dbus_error;
+    if (!domain)
+        domain = "";
 
-    reply = dbus_connection_send_with_reply_and_block (client->bus, message, -1, &error);
+    if (!(b = avahi_new(AvahiServiceTypeBrowser, 1))) {
+        avahi_client_set_errno(client, AVAHI_ERR_NO_MEMORY);
+        goto fail;
+    }
 
-    if (dbus_error_is_set (&error) || reply == NULL)
-        goto dbus_error;
+    b->client = client;
+    b->callback = callback;
+    b->userdata = userdata;
+    b->path = NULL;
 
-    if (!dbus_message_get_args (reply, &error, DBUS_TYPE_OBJECT_PATH, &path, DBUS_TYPE_INVALID))
-        goto dbus_error;
+    AVAHI_LLIST_PREPEND(AvahiServiceTypeBrowser, service_type_browsers, client->service_type_browsers, b);
 
-    if (dbus_error_is_set (&error) || path == NULL)
-        goto dbus_error;
+    if (!(message = dbus_message_new_method_call (AVAHI_DBUS_NAME, AVAHI_DBUS_PATH_SERVER, AVAHI_DBUS_INTERFACE_SERVER, "ServiceTypeBrowserNew"))) {
+        avahi_client_set_errno(client, AVAHI_ERR_NO_MEMORY);
+        goto fail;
+    }
+    
+    i_interface = interface;
+    i_protocol = protocol;
 
-    tmp = malloc (sizeof (AvahiServiceTypeBrowser));
-    tmp->client = client;
-    tmp->callback = callback;
-    tmp->user_data = user_data;
-    tmp->path = strdup (path);
+    if (!dbus_message_append_args(
+            message,
+            DBUS_TYPE_INT32, &interface,
+            DBUS_TYPE_INT32, &protocol,
+            DBUS_TYPE_STRING, &domain,
+            DBUS_TYPE_INVALID)) {
+        avahi_client_set_errno(client, AVAHI_ERR_NO_MEMORY);
+        goto fail;
+    }
 
-    AVAHI_LLIST_PREPEND(AvahiServiceTypeBrowser, service_type_browsers, client->service_type_browsers, tmp);
+    if (!(reply = dbus_connection_send_with_reply_and_block (client->bus, message, -1, &error)) ||
+        dbus_error_is_set(&error)) {
+        avahi_client_set_errno(client, AVAHI_ERR_DBUS_ERROR);
+        goto fail;
+    }
 
-    return tmp;
+    if (!dbus_message_get_args (reply, &error, DBUS_TYPE_OBJECT_PATH, &path, DBUS_TYPE_INVALID) ||
+        dbus_error_is_set(&error) ||
+        !path) {
+        avahi_client_set_errno(client, AVAHI_ERR_DBUS_ERROR);
+        goto fail;
+    }
 
-dbus_error:
-    dbus_error_free (&error);
-    avahi_client_set_errno (client, AVAHI_ERR_DBUS_ERROR);
+    if (!(b->path = avahi_strdup(path))) {
 
-    return NULL;
-}
+        /* FIXME: We don't remove the object on the server side */
 
-void
-avahi_service_type_browser_free (AvahiServiceTypeBrowser *b)
-{
-    DBusMessage *message = NULL;
+        avahi_client_set_errno(client, AVAHI_ERR_NO_MEMORY);
+        goto fail;
+    }
 
-    if (b == NULL || b->path == NULL)
-        return;
+    dbus_message_unref(message);
+    dbus_message_unref(reply);
 
-    message = dbus_message_new_method_call (AVAHI_DBUS_NAME,
-            b->path,
-            AVAHI_DBUS_INTERFACE_SERVICE_TYPE_BROWSER, "Free");
+    return b;
 
-    dbus_connection_send (b->client->bus, message, NULL);
+fail:
+    
+    if (dbus_error_is_set(&error)) {
+        avahi_client_set_dbus_error(client, &error);
+        dbus_error_free(&error);
+    }
 
-    AVAHI_LLIST_REMOVE(AvahiServiceTypeBrowser, service_type_browsers, b->client->service_type_browsers, b);
+    if (b)
+        avahi_service_type_browser_free(b);
+    
+    if (message)
+        dbus_message_unref(message);
 
-    free (b);
+    if (reply)
+        dbus_message_unref(reply);
 
-    return;
+    return NULL;
 }
 
-char*
-avahi_service_type_browser_path (AvahiServiceTypeBrowser *b)
+AvahiClient* avahi_service_type_browser_get_client (AvahiServiceTypeBrowser *b)
 {
-    return b->path;
+    assert(b);
+    return b->client;
 }
 
-DBusHandlerResult
-avahi_service_type_browser_event (AvahiClient *client, AvahiBrowserEvent event, DBusMessage *message)
-{
-    AvahiServiceTypeBrowser *n, *db = NULL;
+int avahi_service_type_browser_free (AvahiServiceTypeBrowser *b) {
+    AvahiClient *client;
+    int r = AVAHI_OK;
+
+    assert(b);
+    client = b->client;
+
+    if (b->path && client->state != AVAHI_CLIENT_DISCONNECTED)
+        r = avahi_client_simple_method_call(client, b->path, AVAHI_DBUS_INTERFACE_SERVICE_TYPE_BROWSER, "Free");
+
+    AVAHI_LLIST_REMOVE(AvahiServiceTypeBrowser, service_type_browsers, b->client->service_type_browsers, b);
+
+    avahi_free(b->path);
+    avahi_free(b);
+    return r;
+}
+
+DBusHandlerResult avahi_service_type_browser_event (AvahiClient *client, AvahiBrowserEvent event, DBusMessage *message) {
+    AvahiServiceTypeBrowser *b = NULL;
     DBusError error;
     const char *path;
     char *domain, *type;
-    int interface, protocol;
+    int32_t interface, protocol;
 
+    assert(client);
+    assert(message);
+    
     dbus_error_init (&error);
 
-    path = dbus_message_get_path (message);
-
-    if (path == NULL)
-        goto out;
+    if (!(path = dbus_message_get_path(message)))
+        goto fail;
 
-    for (n = client->service_type_browsers; n != NULL; n = n->service_type_browsers_next)
-    {
-        printf ("cmp: %s, %s\n", n->path, path);
-        if (strcmp (n->path, path) == 0) {
-            db = n;
+    for (b = client->service_type_browsers; b; b = b->service_type_browsers_next)
+        if (strcmp (b->path, path) == 0)
             break;
-        }
-    }
-
-    if (db == NULL)
-        goto out;
 
-    dbus_message_get_args (message, &error,
-            DBUS_TYPE_INT32, &interface,
-            DBUS_TYPE_INT32, &protocol,
-            DBUS_TYPE_STRING, &type,
-            DBUS_TYPE_STRING, &domain,
-            DBUS_TYPE_INVALID);
-    
-    if (dbus_error_is_set (&error))
-        goto out;
+    if (!b)
+        goto fail;
+
+    if (!dbus_message_get_args(
+              message, &error,
+              DBUS_TYPE_INT32, &interface,
+              DBUS_TYPE_INT32, &protocol,
+              DBUS_TYPE_STRING, &type,
+              DBUS_TYPE_STRING, &domain,
+              DBUS_TYPE_INVALID) ||
+          dbus_error_is_set(&error)) {
+        fprintf(stderr, "Failed to parse browser event.\n");
+        goto fail;
+    }
 
-    db->callback (db, interface, protocol, event, type, domain, db->user_data);
+    b->callback(b, (AvahiIfIndex) interface, (AvahiProtocol) protocol, event, type, domain, b->userdata);
 
     return DBUS_HANDLER_RESULT_HANDLED;
 
-out:
+fail:
     dbus_error_free (&error);
     return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
 }
 
 /* AvahiServiceBrowser */
 
-AvahiServiceBrowser* avahi_service_browser_new (AvahiClient *client, AvahiIfIndex interface, AvahiProtocol protocol, char *type, char *domain, AvahiServiceBrowserCallback callback, void *user_data)
-{
-    AvahiServiceBrowser *tmp = NULL;
-    DBusMessage *message = NULL, *reply;
+AvahiServiceBrowser* avahi_service_browser_new(
+    AvahiClient *client,
+    AvahiIfIndex interface,
+    AvahiProtocol protocol,
+    const char *type,
+    const char *domain,
+    AvahiServiceBrowserCallback callback,
+    void *userdata) {
+    
+    AvahiServiceBrowser *b = NULL;
+    DBusMessage *message = NULL, *reply = NULL;
     DBusError error;
     char *path;
+    int32_t i_protocol, i_interface;
 
-    if (client == NULL)
-        return NULL;
+    assert(client);
+    assert(type);
+    assert(callback);
 
-    dbus_error_init (&error);
+    dbus_error_init(&error);
 
-    message = dbus_message_new_method_call (AVAHI_DBUS_NAME, AVAHI_DBUS_PATH_SERVER,
-            AVAHI_DBUS_INTERFACE_SERVER, "ServiceBrowserNew");
+    if (client->state == AVAHI_CLIENT_DISCONNECTED) {
+        avahi_client_set_errno(client, AVAHI_ERR_BAD_STATE);
+        goto fail;
+    }
 
-    if (!dbus_message_append_args (message,
-                DBUS_TYPE_INT32, &interface,
-                DBUS_TYPE_INT32, &protocol,
-                DBUS_TYPE_STRING, &type,
-                DBUS_TYPE_STRING, &domain,
-                DBUS_TYPE_INVALID))
-        goto dbus_error;
+    if (!domain)
+        domain = "";
 
-    reply = dbus_connection_send_with_reply_and_block (client->bus, message, -1, &error);
+    if (!(b = avahi_new(AvahiServiceBrowser, 1))) {
+        avahi_client_set_errno(client, AVAHI_ERR_NO_MEMORY);
+        goto fail;
+    }
+    
+    b->client = client;
+    b->callback = callback;
+    b->userdata = userdata;
+    b->path = NULL;
 
-    if (dbus_error_is_set (&error) || reply == NULL)
-        goto dbus_error;
+    AVAHI_LLIST_PREPEND(AvahiServiceBrowser, service_browsers, client->service_browsers, b);
 
-    if (!dbus_message_get_args (reply, &error, DBUS_TYPE_OBJECT_PATH, &path, DBUS_TYPE_INVALID))
-        goto dbus_error;
+    if (!(message = dbus_message_new_method_call (AVAHI_DBUS_NAME, AVAHI_DBUS_PATH_SERVER, AVAHI_DBUS_INTERFACE_SERVER, "ServiceBrowserNew"))) {
+        avahi_client_set_errno(client, AVAHI_ERR_NO_MEMORY);
+        goto fail;
+    }
 
-    if (dbus_error_is_set (&error) || path == NULL)
-        goto dbus_error;
+    i_interface = interface;
+    i_protocol = protocol;
+    
 
-    tmp = malloc (sizeof (AvahiServiceBrowser));
-    tmp->client = client;
-    tmp->callback = callback;
-    tmp->user_data = user_data;
-    tmp->path = strdup (path);
+    if (!dbus_message_append_args(
+            message,
+            DBUS_TYPE_INT32, &i_interface,
+            DBUS_TYPE_INT32, &i_protocol,
+            DBUS_TYPE_STRING, &type,
+            DBUS_TYPE_STRING, &domain,
+            DBUS_TYPE_INVALID)) {
+        avahi_client_set_errno(client, AVAHI_ERR_NO_MEMORY);
+        goto fail;
+    }
 
-    AVAHI_LLIST_PREPEND(AvahiServiceBrowser, service_browsers, client->service_browsers, tmp);
+    if (!(reply = dbus_connection_send_with_reply_and_block (client->bus, message, -1, &error)) ||
+        dbus_error_is_set(&error)) {
+        avahi_client_set_errno(client, AVAHI_ERR_DBUS_ERROR);
+        goto fail;
+    }
+
+    if (!dbus_message_get_args (reply, &error, DBUS_TYPE_OBJECT_PATH, &path, DBUS_TYPE_INVALID) ||
+        dbus_error_is_set(&error) ||
+        !path) {
+        avahi_client_set_errno(client, AVAHI_ERR_DBUS_ERROR);
+        goto fail;
+    }
 
-    return tmp;
+    if (!(b->path = avahi_strdup(path))) {
 
-dbus_error:
-    dbus_error_free (&error);
-    avahi_client_set_errno (client, AVAHI_ERR_DBUS_ERROR);
+        /* FIXME: We don't remove the object on the server side */
+
+        avahi_client_set_errno(client, AVAHI_ERR_NO_MEMORY);
+        goto fail;
+    }
+
+    dbus_message_unref(message);
+    dbus_message_unref(reply);
+    
+    return b;
+
+fail:
+    if (dbus_error_is_set(&error)) {
+        avahi_client_set_dbus_error(client, &error);
+        dbus_error_free(&error);
+    }
+
+    if (b)
+        avahi_service_browser_free(b);
+    
+    if (message)
+        dbus_message_unref(message);
+
+    if (reply)
+        dbus_message_unref(reply);
 
     return NULL;
 }
-    
-void
-avahi_service_browser_free (AvahiServiceBrowser *b)
-{
-    DBusMessage *message = NULL;
 
-    if (b == NULL || b->path == NULL)
-        return;
+AvahiClient* avahi_service_browser_get_client (AvahiServiceBrowser *b)
+{
+    assert(b);
+    return b->client;
+}
 
-    printf ("Freeing %s\n", b->path);
+int avahi_service_browser_free (AvahiServiceBrowser *b) {
+    AvahiClient *client;
+    int r = AVAHI_OK;
 
-    message = dbus_message_new_method_call (AVAHI_DBUS_NAME,
-            b->path,
-            AVAHI_DBUS_INTERFACE_SERVICE_BROWSER, "Free");
+    assert(b);
+    client = b->client;
 
-    dbus_connection_send (b->client->bus, message, NULL);
+    if (b->path && client->state != AVAHI_CLIENT_DISCONNECTED)
+        r = avahi_client_simple_method_call(client, b->path, AVAHI_DBUS_INTERFACE_SERVICE_BROWSER, "Free");
 
     AVAHI_LLIST_REMOVE(AvahiServiceBrowser, service_browsers, b->client->service_browsers, b);
 
-    free (b);
-
-    return;
+    avahi_free(b->path);
+    avahi_free(b);
+    return r;
 }
 
-char*
-avahi_service_browser_path (AvahiServiceBrowser *b)
-{
-    return b->path;
-}
 
-DBusHandlerResult
-avahi_service_browser_event (AvahiClient *client, AvahiBrowserEvent event, DBusMessage *message)
-{
-    AvahiServiceBrowser *n, *db = NULL;
+DBusHandlerResult avahi_service_browser_event (AvahiClient *client, AvahiBrowserEvent event, DBusMessage *message) {
+    AvahiServiceBrowser *b = NULL;
     DBusError error;
     const char *path;
     char *name, *type, *domain;
-    int interface, protocol;
+    int32_t interface, protocol;
 
     dbus_error_init (&error);
 
-    path = dbus_message_get_path (message);
+    if (!(path = dbus_message_get_path(message)))
+        goto fail;
 
-    if (path == NULL)
-        goto out;
-
-    for (n = client->service_browsers; n != NULL; n = n->service_browsers_next)
-    {
-        printf ("cmp: %s, %s\n", n->path, path);
-        if (strcmp (n->path, path) == 0) {
-            db = n;
+    for (b = client->service_browsers; b; b = b->service_browsers_next)
+        if (strcmp (b->path, path) == 0)
             break;
-        }
-    }
 
-    if (db == NULL)
-        goto out;
-
-    dbus_message_get_args (message, &error,
-            DBUS_TYPE_INT32, &interface,
-            DBUS_TYPE_INT32, &protocol,
-            DBUS_TYPE_STRING, &name,
-            DBUS_TYPE_STRING, &type,
-            DBUS_TYPE_STRING, &domain,
-            DBUS_TYPE_INVALID);
-
-    if (dbus_error_is_set (&error))
-        goto out;
+    if (!b)
+        goto fail;
+
+    if (!dbus_message_get_args (
+              message, &error,
+              DBUS_TYPE_INT32, &interface,
+              DBUS_TYPE_INT32, &protocol,
+              DBUS_TYPE_STRING, &name,
+              DBUS_TYPE_STRING, &type,
+              DBUS_TYPE_STRING, &domain,
+              DBUS_TYPE_INVALID) ||
+          dbus_error_is_set(&error)) {
+        fprintf(stderr, "Failed to parse browser event.\n");
+        goto fail;
+    }
 
-    db->callback (db, interface, protocol, event, name, type, domain, db->user_data);
+    b->callback(b, (AvahiIfIndex) interface, (AvahiProtocol) protocol, event, name, type, domain, b->userdata);
 
     return DBUS_HANDLER_RESULT_HANDLED;
 
-out:
+fail:
     dbus_error_free (&error);
     return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
 }