/* * salut-avahi-record-browser.c - Source for SalutAvahiRecordBrowser * Copyright (C) 2007 Collabora Ltd. * @author Sjoerd Simons * * This library is free software; you can redistribute it and/or * modify it under the terms of the GNU Lesser General Public * License as published by the Free Software Foundation; either * version 2.1 of the License, or (at your option) any later version. * * This library is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU * Lesser General Public License for more details. * * You should have received a copy of the GNU Lesser General Public * License along with this library; if not, write to the Free Software * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA */ #include #include #include "salut-avahi-record-browser.h" #include "salut-avahi-record-browser-signals-marshal.h" #include "salut-avahi-errors.h" #include "salut-avahi-enums-enumtypes.h" G_DEFINE_TYPE(SalutAvahiRecordBrowser, salut_avahi_record_browser, G_TYPE_OBJECT) /* signal enum */ enum { NEW, REMOVED, FAILURE, ALL_FOR_NOW, CACHE_EXHAUSTED, LAST_SIGNAL }; static guint signals[LAST_SIGNAL] = {0}; /* properties */ enum { PROP_PROTOCOL = 1, PROP_IFINDEX, PROP_NAME, PROP_CLASS, PROP_TYPE, PROP_FLAGS, }; /* private structure */ typedef struct _SalutAvahiRecordBrowserPrivate SalutAvahiRecordBrowserPrivate; struct _SalutAvahiRecordBrowserPrivate { gboolean dispose_has_run; SalutAvahiClient *client; AvahiRecordBrowser *browser; AvahiProtocol protocol; AvahiIfIndex interface; gchar *name; guint16 class; guint16 type; AvahiLookupFlags flags; }; #define SALUT_AVAHI_RECORD_BROWSER_GET_PRIVATE(o) (G_TYPE_INSTANCE_GET_PRIVATE ((o), SALUT_TYPE_AVAHI_RECORD_BROWSER, SalutAvahiRecordBrowserPrivate)) static void salut_avahi_record_browser_init (SalutAvahiRecordBrowser *obj) { /* allocate any data required by the object here */ } static void salut_avahi_record_browser_dispose (GObject *object); static void salut_avahi_record_browser_finalize (GObject *object); static void salut_avahi_record_browser_set_property (GObject *object, guint property_id, const GValue *value, GParamSpec *pspec) { SalutAvahiRecordBrowser *browser = SALUT_AVAHI_RECORD_BROWSER(object); SalutAvahiRecordBrowserPrivate *priv = SALUT_AVAHI_RECORD_BROWSER_GET_PRIVATE(browser); g_assert(priv->browser == NULL); switch (property_id) { case PROP_PROTOCOL: priv->protocol = g_value_get_enum(value); break; case PROP_IFINDEX: priv->interface = g_value_get_int(value); break; case PROP_NAME: priv->name = g_value_dup_string(value); break; case PROP_CLASS: priv->class = g_value_get_uint(value); break; case PROP_TYPE: priv->type = g_value_get_uint(value); break; case PROP_FLAGS: priv->flags = g_value_get_enum(value); break; default: G_OBJECT_WARN_INVALID_PROPERTY_ID (object, property_id, pspec); break; } } static void salut_avahi_record_browser_get_property (GObject *object, guint property_id, GValue *value, GParamSpec *pspec) { SalutAvahiRecordBrowser *browser = SALUT_AVAHI_RECORD_BROWSER(object); SalutAvahiRecordBrowserPrivate *priv = SALUT_AVAHI_RECORD_BROWSER_GET_PRIVATE(browser); switch (property_id) { case PROP_PROTOCOL: g_value_set_int(value, priv->protocol); break; case PROP_IFINDEX: g_value_set_int(value, priv->interface); break; case PROP_TYPE: g_value_set_uint(value, priv->type); break; case PROP_CLASS: g_value_set_uint(value, priv->class); break; case PROP_NAME: g_value_set_string(value, priv->name); break; case PROP_FLAGS: g_value_set_enum(value, priv->flags); break; default: G_OBJECT_WARN_INVALID_PROPERTY_ID (object, property_id, pspec); break; } } static void salut_avahi_record_browser_class_init (SalutAvahiRecordBrowserClass *salut_avahi_record_browser_class) { GObjectClass *object_class = G_OBJECT_CLASS (salut_avahi_record_browser_class); GParamSpec *param_spec; g_type_class_add_private (salut_avahi_record_browser_class, sizeof (SalutAvahiRecordBrowserPrivate)); object_class->dispose = salut_avahi_record_browser_dispose; object_class->finalize = salut_avahi_record_browser_finalize; object_class->set_property = salut_avahi_record_browser_set_property; object_class->get_property = salut_avahi_record_browser_get_property; signals[NEW] = g_signal_new("new-record", G_OBJECT_CLASS_TYPE(salut_avahi_record_browser_class), G_SIGNAL_RUN_LAST, 0, NULL, NULL, salut_avahi_record_browser_marshal_VOID__INT_ENUM_STRING_UINT_UINT_POINTER_INT_INT, G_TYPE_NONE, 8, G_TYPE_INT, SALUT_TYPE_AVAHI_PROTOCOL, G_TYPE_STRING, G_TYPE_UINT, G_TYPE_UINT, G_TYPE_POINTER, G_TYPE_INT, SALUT_TYPE_AVAHI_LOOKUP_RESULT_FLAGS); signals[REMOVED] = g_signal_new("removed-record", G_OBJECT_CLASS_TYPE(salut_avahi_record_browser_class), G_SIGNAL_RUN_LAST, 0, NULL, NULL, salut_avahi_record_browser_marshal_VOID__INT_ENUM_STRING_UINT_UINT_POINTER_INT_INT, G_TYPE_NONE, 8, G_TYPE_INT, SALUT_TYPE_AVAHI_PROTOCOL, G_TYPE_STRING, G_TYPE_UINT, G_TYPE_UINT, G_TYPE_POINTER, G_TYPE_INT, SALUT_TYPE_AVAHI_LOOKUP_RESULT_FLAGS); signals[ALL_FOR_NOW] = g_signal_new("all-for-now", G_OBJECT_CLASS_TYPE(salut_avahi_record_browser_class), G_SIGNAL_RUN_LAST, 0, NULL, NULL, g_cclosure_marshal_VOID__VOID, G_TYPE_NONE, 0); signals[CACHE_EXHAUSTED] = g_signal_new("cache-exhausted", G_OBJECT_CLASS_TYPE(salut_avahi_record_browser_class), G_SIGNAL_RUN_LAST, 0, NULL, NULL, g_cclosure_marshal_VOID__VOID, G_TYPE_NONE, 0); signals[FAILURE] = g_signal_new("failure", G_OBJECT_CLASS_TYPE(salut_avahi_record_browser_class), G_SIGNAL_RUN_LAST, 0, NULL, NULL, g_cclosure_marshal_VOID__POINTER, G_TYPE_NONE, 1, G_TYPE_POINTER); param_spec = g_param_spec_enum("protocol", "Avahi protocol to browse", "Avahi protocol to browse", SALUT_TYPE_AVAHI_PROTOCOL, SALUT_AVAHI_PROTOCOL_UNSPEC, G_PARAM_READWRITE | G_PARAM_STATIC_NAME | G_PARAM_STATIC_BLURB); g_object_class_install_property(object_class, PROP_PROTOCOL, param_spec); param_spec = g_param_spec_int("interface", "interface index", "Interface use for browser", AVAHI_IF_UNSPEC, G_MAXINT, AVAHI_IF_UNSPEC, G_PARAM_READWRITE | G_PARAM_STATIC_NAME | G_PARAM_STATIC_BLURB); g_object_class_install_property(object_class, PROP_IFINDEX, param_spec); param_spec = g_param_spec_string("name", "record name", "Record name to browse for", NULL, G_PARAM_READWRITE | G_PARAM_STATIC_NAME | G_PARAM_STATIC_BLURB); g_object_class_install_property(object_class, PROP_NAME, param_spec); param_spec = g_param_spec_uint("type", "record type", "Record type to browse for", 0, G_MAXUINT16, 0, G_PARAM_READWRITE | G_PARAM_STATIC_NAME | G_PARAM_STATIC_BLURB); g_object_class_install_property(object_class, PROP_TYPE, param_spec); param_spec = g_param_spec_uint("class", "record class", "Record class to browse for", 0, G_MAXUINT16, 0, G_PARAM_READWRITE | G_PARAM_STATIC_NAME | G_PARAM_STATIC_BLURB); g_object_class_install_property(object_class, PROP_CLASS, param_spec); param_spec = g_param_spec_enum("flags", "Lookup flags for the browser", "Browser lookup flags", SALUT_TYPE_AVAHI_PROTOCOL, SALUT_AVAHI_LOOKUP_NO_FLAGS, G_PARAM_READWRITE | G_PARAM_STATIC_NAME | G_PARAM_STATIC_BLURB); g_object_class_install_property(object_class, PROP_FLAGS, param_spec); } void salut_avahi_record_browser_dispose (GObject *object) { SalutAvahiRecordBrowser *self = SALUT_AVAHI_RECORD_BROWSER (object); SalutAvahiRecordBrowserPrivate *priv = SALUT_AVAHI_RECORD_BROWSER_GET_PRIVATE (self); if (priv->dispose_has_run) return; priv->dispose_has_run = TRUE; /* release any references held by the object here */ if (priv->client) g_object_unref(priv->client); priv->client = NULL; if (priv->browser) avahi_record_browser_free(priv->browser); priv->browser = NULL; if (G_OBJECT_CLASS (salut_avahi_record_browser_parent_class)->dispose) G_OBJECT_CLASS (salut_avahi_record_browser_parent_class)->dispose (object); } void salut_avahi_record_browser_finalize (GObject *object) { SalutAvahiRecordBrowser *self = SALUT_AVAHI_RECORD_BROWSER (object); SalutAvahiRecordBrowserPrivate *priv = SALUT_AVAHI_RECORD_BROWSER_GET_PRIVATE (self); /* free any data held directly by the object here */ g_free(priv->name); G_OBJECT_CLASS (salut_avahi_record_browser_parent_class)->finalize (object); } SalutAvahiRecordBrowser * salut_avahi_record_browser_new(const gchar *name, guint16 type) { return salut_avahi_record_browser_new_full(AVAHI_IF_UNSPEC, AVAHI_PROTO_UNSPEC, name, AVAHI_DNS_CLASS_IN, type, 0); } SalutAvahiRecordBrowser * salut_avahi_record_browser_new_full(AvahiIfIndex interface, AvahiProtocol protocol, const gchar *name, guint16 clazz, guint16 type, SalutAvahiLookupFlags flags) { return g_object_new(SALUT_TYPE_AVAHI_RECORD_BROWSER, "interface", interface, "protocol", protocol, "name", name, "class", clazz, "type", type, "flags", flags, NULL); } static void _avahi_record_browser_cb(AvahiRecordBrowser *r, AvahiIfIndex interface, AvahiProtocol protocol, AvahiBrowserEvent event, const char *name, uint16_t clazz, uint16_t type, const void *rdata, size_t rdata_size, AvahiLookupResultFlags flags, void *userdata) { SalutAvahiRecordBrowser *self = SALUT_AVAHI_RECORD_BROWSER(userdata); SalutAvahiRecordBrowserPrivate *priv = SALUT_AVAHI_RECORD_BROWSER_GET_PRIVATE(userdata); switch (event) { case AVAHI_BROWSER_NEW: case AVAHI_BROWSER_REMOVE: { guint signalid = (event == AVAHI_BROWSER_NEW ? NEW : REMOVED); g_signal_emit(self, signals[signalid], 0, interface, protocol, name, clazz, type, rdata, rdata_size, flags); break; } case AVAHI_BROWSER_CACHE_EXHAUSTED: g_signal_emit(self, signals[CACHE_EXHAUSTED], 0); break; case AVAHI_BROWSER_ALL_FOR_NOW: g_signal_emit(self, signals[ALL_FOR_NOW], 0); break; case AVAHI_BROWSER_FAILURE: { GError *error; int aerrno = avahi_client_errno(priv->client->avahi_client); error = g_error_new(SALUT_AVAHI_ERRORS, aerrno, "Browsing failed: %s", avahi_strerror(aerrno)); g_signal_emit(self, signals[FAILURE], 0, error); g_error_free(error); break; } } } gboolean salut_avahi_record_browser_attach(SalutAvahiRecordBrowser *browser, SalutAvahiClient *client, GError **error) { SalutAvahiRecordBrowserPrivate *priv = SALUT_AVAHI_RECORD_BROWSER_GET_PRIVATE(browser); priv->client = g_object_ref(client); priv->browser = avahi_record_browser_new(client->avahi_client, priv->interface, priv->protocol, priv->name, priv->class, priv->type, priv->flags, _avahi_record_browser_cb, browser); if (priv->browser == NULL) { if (error != NULL ) { int aerrno = avahi_client_errno(client->avahi_client); *error = g_error_new(SALUT_AVAHI_ERRORS, aerrno, "Attaching record browser failed: %s", avahi_strerror(aerrno)); } return FALSE; } return TRUE; }