diff options
Diffstat (limited to 'avahi-gobject/ga-record-browser.c')
| -rw-r--r-- | avahi-gobject/ga-record-browser.c | 381 |
1 files changed, 381 insertions, 0 deletions
diff --git a/avahi-gobject/ga-record-browser.c b/avahi-gobject/ga-record-browser.c new file mode 100644 index 0000000..f6747cd --- /dev/null +++ b/avahi-gobject/ga-record-browser.c @@ -0,0 +1,381 @@ +/* + * ga-record-browser.c - Source for GaRecordBrowser + * Copyright (C) 2007 Collabora Ltd. + * @author Sjoerd Simons <sjoerd@luon.net> + * + * 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 + */ + +#ifdef HAVE_CONFIG_H +#include <config.h> +#endif + +#include <stdio.h> +#include <stdlib.h> + +#include "ga-record-browser.h" +#include "signals-marshal.h" +#include "ga-errors.h" +#include "ga-enums-enumtypes.h" + +G_DEFINE_TYPE(GaRecordBrowser, ga_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 _GaRecordBrowserPrivate GaRecordBrowserPrivate; + +struct _GaRecordBrowserPrivate { + gboolean dispose_has_run; + GaClient *client; + AvahiRecordBrowser *browser; + AvahiProtocol protocol; + AvahiIfIndex interface; + gchar *name; + guint16 class; + guint16 type; + AvahiLookupFlags flags; +}; + +#define GA_RECORD_BROWSER_GET_PRIVATE(o) (G_TYPE_INSTANCE_GET_PRIVATE ((o), GA_TYPE_RECORD_BROWSER, GaRecordBrowserPrivate)) + +static void ga_record_browser_init(AVAHI_GCC_UNUSED GaRecordBrowser * obj) { + /* allocate any data required by the object here */ +} + +static void ga_record_browser_dispose(GObject * object); +static void ga_record_browser_finalize(GObject * object); + +static void ga_record_browser_set_property(GObject * object, + guint property_id, + const GValue * value, GParamSpec * pspec) { + GaRecordBrowser *browser = GA_RECORD_BROWSER(object); + GaRecordBrowserPrivate *priv = GA_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 ga_record_browser_get_property(GObject * object, + guint property_id, + GValue * value, GParamSpec * pspec) { + GaRecordBrowser *browser = GA_RECORD_BROWSER(object); + GaRecordBrowserPrivate *priv = GA_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 ga_record_browser_class_init(GaRecordBrowserClass * ga_record_browser_class) { + GObjectClass *object_class = G_OBJECT_CLASS(ga_record_browser_class); + GParamSpec *param_spec; + + g_type_class_add_private(ga_record_browser_class, + sizeof (GaRecordBrowserPrivate)); + + object_class->dispose = ga_record_browser_dispose; + object_class->finalize = ga_record_browser_finalize; + + object_class->set_property = ga_record_browser_set_property; + object_class->get_property = ga_record_browser_get_property; + + signals[NEW] = + g_signal_new("new-record", + G_OBJECT_CLASS_TYPE(ga_record_browser_class), + G_SIGNAL_RUN_LAST, + 0, + NULL, NULL, + ga_signals_marshal_VOID__INT_ENUM_STRING_UINT_UINT_POINTER_INT_INT, + G_TYPE_NONE, 8, + G_TYPE_INT, + GA_TYPE_PROTOCOL, + G_TYPE_STRING, + G_TYPE_UINT, + G_TYPE_UINT, + G_TYPE_POINTER, + G_TYPE_INT, GA_TYPE_LOOKUP_RESULT_FLAGS); + + signals[REMOVED] = + g_signal_new("removed-record", + G_OBJECT_CLASS_TYPE(ga_record_browser_class), + G_SIGNAL_RUN_LAST, + 0, + NULL, NULL, + ga_signals_marshal_VOID__INT_ENUM_STRING_UINT_UINT_POINTER_INT_INT, + G_TYPE_NONE, 8, + G_TYPE_INT, + GA_TYPE_PROTOCOL, + G_TYPE_STRING, + G_TYPE_UINT, + G_TYPE_UINT, + G_TYPE_POINTER, + G_TYPE_INT, GA_TYPE_LOOKUP_RESULT_FLAGS); + + signals[ALL_FOR_NOW] = + g_signal_new("all-for-now", + G_OBJECT_CLASS_TYPE(ga_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(ga_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(ga_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", + GA_TYPE_PROTOCOL, + GA_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", + GA_TYPE_PROTOCOL, + GA_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 ga_record_browser_dispose(GObject * object) { + GaRecordBrowser *self = GA_RECORD_BROWSER(object); + GaRecordBrowserPrivate *priv = GA_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(ga_record_browser_parent_class)->dispose) + G_OBJECT_CLASS(ga_record_browser_parent_class)->dispose(object); +} + +void ga_record_browser_finalize(GObject * object) { + GaRecordBrowser *self = GA_RECORD_BROWSER(object); + GaRecordBrowserPrivate *priv = GA_RECORD_BROWSER_GET_PRIVATE(self); + + /* free any data held directly by the object here */ + g_free(priv->name); + + G_OBJECT_CLASS(ga_record_browser_parent_class)->finalize(object); +} + + +GaRecordBrowser *ga_record_browser_new(const gchar * name, guint16 type) { + return ga_record_browser_new_full(AVAHI_IF_UNSPEC, + AVAHI_PROTO_UNSPEC, name, + AVAHI_DNS_CLASS_IN, type, 0); +} + +GaRecordBrowser *ga_record_browser_new_full(AvahiIfIndex interface, + AvahiProtocol protocol, + const gchar * name, + guint16 clazz, + guint16 type, + GaLookupFlags flags) { + return g_object_new(GA_TYPE_RECORD_BROWSER, + "interface", interface, + "protocol", protocol, + "name", name, + "class", clazz, "type", type, "flags", flags, NULL); + +} + +static void _avahi_record_browser_cb(AVAHI_GCC_UNUSED 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) { + GaRecordBrowser *self = GA_RECORD_BROWSER(userdata); + GaRecordBrowserPrivate *priv = GA_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(GA_ERRORS, aerrno, + "Browsing failed: %s", + avahi_strerror(aerrno)); + g_signal_emit(self, signals[FAILURE], 0, error); + g_error_free(error); + break; + } + } +} + +gboolean ga_record_browser_attach(GaRecordBrowser * browser, + GaClient * client, GError ** error) { + GaRecordBrowserPrivate *priv = GA_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(GA_ERRORS, aerrno, + "Attaching record browser failed: %s", + avahi_strerror(aerrno)); + } + return FALSE; + } + return TRUE; +} |