+++ /dev/null
-/*
- * 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-error.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_LOOKUP_FLAGS,
- 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_ERROR, 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_ERROR, aerrno,
- "Attaching record browser failed: %s",
- avahi_strerror(aerrno));
- }
- return FALSE;
- }
- return TRUE;
-}
projects / catta / blobdiff