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