summaryrefslogtreecommitdiffstats
path: root/avahi-glib/ga-record-browser.c
diff options
context:
space:
mode:
Diffstat (limited to 'avahi-glib/ga-record-browser.c')
-rw-r--r--avahi-glib/ga-record-browser.c381
1 files changed, 381 insertions, 0 deletions
diff --git a/avahi-glib/ga-record-browser.c b/avahi-glib/ga-record-browser.c
new file mode 100644
index 0000000..f6747cd
--- /dev/null
+++ b/avahi-glib/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;
+}