/*
* 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;
}