X-Git-Url: http://git.meshlink.io/?a=blobdiff_plain;f=avahi-client%2Fbrowser.c;h=a83aa697da597c4d0ecfb813b817758b1a9d4c15;hb=cb6f8a5396aa9bc32619ddd74ead4f3ff209d200;hp=e994d2af54d40bab604bba0eb01547e6a7edf9db;hpb=769c00f228ba0d37217aaf1424dedde390e7a01c;p=catta

diff --git a/avahi-client/browser.c b/avahi-client/browser.c
index e994d2a..a83aa69 100644
--- a/avahi-client/browser.c
+++ b/avahi-client/browser.c
@@ -28,7 +28,6 @@
 #include <string.h>
 
 #include <dbus/dbus.h>
-#include <dbus/dbus-glib-lowlevel.h>
 
 #include <avahi-client/client.h>
 #include <avahi-common/dbus.h>
@@ -39,380 +38,537 @@
 #include "client.h"
 #include "internal.h"
 
-/* AvahiDomainBrowser */
-
-AvahiDomainBrowser* avahi_domain_browser_new (AvahiClient *client, AvahiIfIndex interface, AvahiProtocol protocol, const 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,
+    AvahiLookupFlags flags,
+    AvahiDomainBrowserCallback callback,
+    void *userdata) {
+    
+    AvahiDomainBrowser *db = NULL;
+    DBusMessage *message = NULL, *reply = NULL;
     DBusError error;
     char *path;
+    int32_t i_interface, i_protocol, bt;
+    uint32_t u_flags;
 
-    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 (!domain)
+        domain = "";
+
+    if (!(db = avahi_new (AvahiDomainBrowser, 1))) {
+        avahi_client_set_errno(client, AVAHI_ERR_NO_MEMORY);
+        goto fail;
+    }
+
+    db->client = client;
+    db->callback = callback;
+    db->userdata = userdata;
+    db->path = NULL;
 
-    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;
+    AVAHI_LLIST_PREPEND(AvahiDomainBrowser, domain_browsers, client->domain_browsers, db);
 
-    reply = dbus_connection_send_with_reply_and_block (client->bus, message, -1, &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;
+    }
+
+    i_interface = (int32_t) interface;
+    i_protocol = (int32_t) protocol;
+    u_flags = (uint32_t) flags;
+    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_UINT32, &flags,
+              DBUS_TYPE_INVALID))) {
+        avahi_client_set_errno(client, AVAHI_ERR_NO_MEMORY);
+        goto fail;
+    }
 
-    if (dbus_error_is_set (&error) || reply == NULL)
-        goto dbus_error;
+    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))
-        goto dbus_error;
+    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;
+    }
 
-    if (dbus_error_is_set (&error) || path == NULL)
-        goto dbus_error;
+    if (!(db->path = avahi_strdup(path))) {
 
-    tmp = avahi_new (AvahiDomainBrowser, 1);
-    tmp->client = client;
-    tmp->callback = callback;
-    tmp->user_data = user_data;
-    tmp->path = strdup (path);
+        /* FIXME: We don't remove the object on the server side */
 
-    AVAHI_LLIST_PREPEND(AvahiDomainBrowser, domain_browsers, client->domain_browsers, tmp);
+        avahi_client_set_errno(client, AVAHI_ERR_NO_MEMORY);
+        goto fail;
+    }
 
-    return tmp;
+    dbus_message_unref(message);
+    dbus_message_unref(reply);
+    
+    return db;
 
-dbus_error:
-    dbus_error_free (&error);
-    avahi_client_set_errno (client, AVAHI_ERR_DBUS_ERROR);
+fail:
+
+    if (dbus_error_is_set(&error)) {
+        avahi_client_set_dbus_error(client, &error);
+        dbus_error_free(&error);
+    }
+
+    if (db)
+        avahi_domain_browser_free(db);
+    
+    if (message)
+        dbus_message_unref(message);
+
+    if (reply)
+        dbus_message_unref(reply);
 
     return NULL;
 }
 
-int
-avahi_domain_browser_free (AvahiDomainBrowser *b)
+AvahiClient* avahi_domain_browser_get_client (AvahiDomainBrowser *b)
 {
-    AvahiClient *client = b->client;
-    DBusMessage *message = NULL;
-
-    if (b == NULL || b->path == NULL)
-        return avahi_client_set_errno (client, AVAHI_ERR_INVALID_OBJECT);
+    assert(b);
+    return b->client;
+}
 
-    message = dbus_message_new_method_call (AVAHI_DBUS_NAME,
-            b->path,
-            AVAHI_DBUS_INTERFACE_DOMAIN_BROWSER, "Free");
+int avahi_domain_browser_free (AvahiDomainBrowser *b) {
+    AvahiClient *client;
+    int r = AVAHI_OK;
 
-    if (message == NULL)
-        return avahi_client_set_errno (client, AVAHI_ERR_DBUS_ERROR);
+    assert(b);
+    client = b->client;
 
-    dbus_connection_send (client->bus, message, NULL);
+    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);
-
-    return avahi_client_set_errno (client, AVAHI_OK);
-}
+    avahi_free(b->path);
+    avahi_free(b);
 
-const char*
-avahi_domain_browser_path (AvahiDomainBrowser *b)
-{
-    return b->path;
+    return r;
 }
 
-DBusHandlerResult
-avahi_domain_browser_event (AvahiClient *client, AvahiBrowserEvent event, DBusMessage *message)
-{
-    AvahiDomainBrowser *n, *db = NULL;
+DBusHandlerResult avahi_domain_browser_event (AvahiClient *client, AvahiBrowserEvent event, DBusMessage *message) {
+    AvahiDomainBrowser *db = NULL;
     DBusError error;
     const char *path;
-    char *domain;
-    int interface, protocol;
+    char *domain = NULL;
+    int32_t interface = AVAHI_IF_UNSPEC, protocol = AVAHI_PROTO_UNSPEC;
+    uint32_t flags = 0;
 
+    assert(client);
+    assert(message);
+    
     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->domain_browsers; n != NULL; n = n->domain_browsers_next)
-    {
-        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 (!db)
+        goto fail;
 
-    if (dbus_error_is_set (&error))
-        goto out;
+    if (event == AVAHI_BROWSER_NEW || event == AVAHI_BROWSER_REMOVE) {
+        if (!dbus_message_get_args(
+                message, &error,
+                DBUS_TYPE_INT32, &interface,
+                DBUS_TYPE_INT32, &protocol,
+                DBUS_TYPE_STRING, &domain,
+                DBUS_TYPE_UINT32, &flags,
+                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, (AvahiLookupResultFlags) flags, 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, const 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,
+    AvahiLookupFlags flags, 
+    AvahiServiceTypeBrowserCallback callback,
+    void *userdata) {
+        
+    AvahiServiceTypeBrowser *b = NULL;
+    DBusMessage *message = NULL, *reply = NULL;
     DBusError error;
     char *path;
+    int32_t i_interface, i_protocol;
+    uint32_t u_flags;
 
-    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 = (int32_t) interface;
+    i_protocol = (int32_t) protocol;
+    u_flags = (uint32_t) flags;
+
+    if (!dbus_message_append_args(
+            message,
+            DBUS_TYPE_INT32, &i_interface,
+            DBUS_TYPE_INT32, &i_protocol,
+            DBUS_TYPE_STRING, &domain,
+            DBUS_TYPE_UINT32, &u_flags,
+            DBUS_TYPE_INVALID)) {
+        avahi_client_set_errno(client, AVAHI_ERR_NO_MEMORY);
+        goto fail;
+    }
 
-    tmp = avahi_new(AvahiServiceTypeBrowser, 1);
-    tmp->client = client;
-    tmp->callback = callback;
-    tmp->user_data = user_data;
-    tmp->path = strdup (path);
+    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;
+    }
 
-    AVAHI_LLIST_PREPEND(AvahiServiceTypeBrowser, service_type_browsers, client->service_type_browsers, 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;
+    }
 
-    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_type_browser_free(b);
+    
+    if (message)
+        dbus_message_unref(message);
+
+    if (reply)
+        dbus_message_unref(reply);
 
     return NULL;
 }
 
-int
-avahi_service_type_browser_free (AvahiServiceTypeBrowser *b)
+AvahiClient* avahi_service_type_browser_get_client (AvahiServiceTypeBrowser *b)
 {
-    AvahiClient *client = b->client;
-    DBusMessage *message = NULL;
-
-    if (b == NULL || b->path == NULL)
-        return avahi_client_set_errno (client, AVAHI_ERR_INVALID_OBJECT);
+    assert(b);
+    return b->client;
+}
 
-    message = dbus_message_new_method_call (AVAHI_DBUS_NAME,
-            b->path,
-            AVAHI_DBUS_INTERFACE_SERVICE_TYPE_BROWSER, "Free");
+int avahi_service_type_browser_free (AvahiServiceTypeBrowser *b) {
+    AvahiClient *client;
+    int r = AVAHI_OK;
 
-    if (message == NULL)
-        return avahi_client_set_errno (client, AVAHI_ERR_DBUS_ERROR);
+    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_TYPE_BROWSER, "Free");
 
     AVAHI_LLIST_REMOVE(AvahiServiceTypeBrowser, service_type_browsers, b->client->service_type_browsers, b);
 
-    avahi_free (b);
-
-    return avahi_client_set_errno (client, AVAHI_OK);
+    avahi_free(b->path);
+    avahi_free(b);
+    return r;
 }
 
-const char*
-avahi_service_type_browser_path (AvahiServiceTypeBrowser *b)
-{
-    return b->path;
-}
-
-DBusHandlerResult
-avahi_service_type_browser_event (AvahiClient *client, AvahiBrowserEvent event, DBusMessage *message)
-{
-    AvahiServiceTypeBrowser *n, *db = NULL;
+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;
+    char *domain = NULL, *type = NULL;
+    int32_t interface = AVAHI_IF_UNSPEC, protocol = AVAHI_PROTO_UNSPEC;
+    uint32_t flags = 0;
 
+    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)
-    {
-        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;
+    if (!b)
+        goto fail;
 
-    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 (event == AVAHI_BROWSER_NEW || event == AVAHI_BROWSER_REMOVE) {
+        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_UINT32, &flags,
+                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, (AvahiLookupResultFlags) flags, 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, const char *type, const 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,
+    AvahiLookupFlags flags, 
+    AvahiServiceBrowserCallback callback,
+    void *userdata) {
+    
+    AvahiServiceBrowser *b = NULL;
+    DBusMessage *message = NULL, *reply = NULL;
     DBusError error;
     char *path;
+    int32_t i_protocol, i_interface;
+    uint32_t u_flags;
 
-    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 = "";
+
+    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;
+
+    AVAHI_LLIST_PREPEND(AvahiServiceBrowser, service_browsers, client->service_browsers, b);
+
+    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;
+    }
+
+    i_interface = (int32_t) interface;
+    i_protocol = (int32_t) protocol;
+    u_flags = (uint32_t) flags;
+
+    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_UINT32, &u_flags,
+            DBUS_TYPE_INVALID)) {
+        avahi_client_set_errno(client, AVAHI_ERR_NO_MEMORY);
+        goto fail;
+    }
+
+    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;
+    }
 
-    reply = dbus_connection_send_with_reply_and_block (client->bus, message, -1, &error);
+    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;
+    }
 
-    if (dbus_error_is_set (&error) || reply == NULL)
-        goto dbus_error;
+    if (!(b->path = avahi_strdup(path))) {
 
-    if (!dbus_message_get_args (reply, &error, DBUS_TYPE_OBJECT_PATH, &path, DBUS_TYPE_INVALID))
-        goto dbus_error;
+        /* FIXME: We don't remove the object on the server side */
 
-    if (dbus_error_is_set (&error) || path == NULL)
-        goto dbus_error;
+        avahi_client_set_errno(client, AVAHI_ERR_NO_MEMORY);
+        goto fail;
+    }
 
-    tmp = avahi_new(AvahiServiceBrowser, 1);
-    tmp->client = client;
-    tmp->callback = callback;
-    tmp->user_data = user_data;
-    tmp->path = strdup (path);
+    dbus_message_unref(message);
+    dbus_message_unref(reply);
+    
+    return b;
 
-    AVAHI_LLIST_PREPEND(AvahiServiceBrowser, service_browsers, client->service_browsers, tmp);
+fail:
+    if (dbus_error_is_set(&error)) {
+        avahi_client_set_dbus_error(client, &error);
+        dbus_error_free(&error);
+    }
 
-    return tmp;
+    if (b)
+        avahi_service_browser_free(b);
+    
+    if (message)
+        dbus_message_unref(message);
 
-dbus_error:
-    dbus_error_free (&error);
-    avahi_client_set_errno (client, AVAHI_ERR_DBUS_ERROR);
+    if (reply)
+        dbus_message_unref(reply);
 
     return NULL;
 }
-    
-int
-avahi_service_browser_free (AvahiServiceBrowser *b)
+
+AvahiClient* avahi_service_browser_get_client (AvahiServiceBrowser *b)
 {
-    AvahiClient *client = b->client;
-    DBusMessage *message = NULL;
-    
-    if (b == NULL || b->path == NULL)
-        return avahi_client_set_errno (client, AVAHI_ERR_INVALID_OBJECT);
+    assert(b);
+    return b->client;
+}
 
-    message = dbus_message_new_method_call (AVAHI_DBUS_NAME,
-            b->path,
-            AVAHI_DBUS_INTERFACE_SERVICE_BROWSER, "Free");
+int avahi_service_browser_free (AvahiServiceBrowser *b) {
+    AvahiClient *client;
+    int r = AVAHI_OK;
 
-    if (message == NULL)
-        return avahi_client_set_errno (client, AVAHI_ERR_DBUS_ERROR);
+    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);
 
-    avahi_free (b);
-
-    return avahi_client_set_errno (client, AVAHI_OK);
+    avahi_free(b->path);
+    avahi_free(b);
+    return r;
 }
 
-const 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;
+    char *name = NULL, *type = NULL, *domain = NULL;
+    int32_t interface = AVAHI_IF_UNSPEC, protocol = AVAHI_PROTO_UNSPEC;
+    uint32_t flags = 0;
 
     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_browsers; n != NULL; n = n->service_browsers_next)
-    {
-        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;
+    if (!b)
+        goto fail;
 
-    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 (event == AVAHI_BROWSER_NEW || event == AVAHI_BROWSER_REMOVE) {
+        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_UINT32, &flags,
+                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, (AvahiLookupResultFlags) flags, b->userdata);
 
     return DBUS_HANDLER_RESULT_HANDLED;
 
-out:
+fail:
     dbus_error_free (&error);
     return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
 }