summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--avahi-client/client-test.c21
-rw-r--r--avahi-client/client.c194
-rw-r--r--avahi-client/client.h23
3 files changed, 235 insertions, 3 deletions
diff --git a/avahi-client/client-test.c b/avahi-client/client-test.c
index 71d5096..cc41f49 100644
--- a/avahi-client/client-test.c
+++ b/avahi-client/client-test.c
@@ -1,15 +1,32 @@
#include <avahi-client/client.h>
#include <stdio.h>
+#include <glib.h>
int
main (int argc, char *argv[])
{
+ GMainLoop *loop;
AvahiClient *avahi;
+ char *ret;
+
+ loop = g_main_loop_new (NULL, FALSE);
avahi = avahi_client_new ();
- if (avahi != NULL)
- free (avahi);
+ g_assert (avahi != NULL);
+
+ ret = avahi_client_get_version_string (avahi);
+ printf ("Avahi Server Version: %s\n", ret);
+
+ ret = avahi_client_get_host_name (avahi);
+ printf ("Host Name: %s\n", ret);
+
+ ret = avahi_client_get_alternative_host_name (avahi, "ubuntu");
+ printf ("Alternative Host Name: %s\n", ret);
+
+ g_free (avahi);
+
+ g_main_loop_run (loop);
return 0;
}
diff --git a/avahi-client/client.c b/avahi-client/client.c
index 3643403..6ff099a 100644
--- a/avahi-client/client.c
+++ b/avahi-client/client.c
@@ -1,18 +1,212 @@
#include <avahi-client/client.h>
#include <avahi-common/dbus.h>
+#include <stdlib.h>
+#include <stdio.h>
#include <glib.h>
+#include <string.h>
#define DBUS_API_SUBJECT_TO_CHANGE
#include <dbus/dbus.h>
+#include <dbus/dbus-glib-lowlevel.h>
#include <stdlib.h>
+struct _AvahiClientPriv
+{
+ DBusConnection *bus;
+};
+
+static DBusHandlerResult
+filter_func (DBusConnection *bus, DBusMessage *message, void *data)
+{
+ DBusError error;
+
+ g_assert (bus != NULL);
+ g_assert (message != NULL);
+
+ printf ("dbus: interface=%s, path=%s, member=%s\n",
+ dbus_message_get_interface (message),
+ dbus_message_get_path (message),
+ dbus_message_get_member (message));
+
+ dbus_error_init (&error);
+
+ if (dbus_message_is_signal(message, DBUS_INTERFACE_DBUS, "NameOwnerChanged")) {
+ gchar *name, *old, *new;
+ dbus_message_get_args(message, &error, DBUS_TYPE_STRING, &name, DBUS_TYPE_STRING, &old, DBUS_TYPE_STRING, &new, DBUS_TYPE_INVALID);
+
+ if (dbus_error_is_set (&error)) {
+ fprintf(stderr, "Failed to parse NameOwnerChanged message: %s", error.message);
+ dbus_error_free (&error);
+ goto out;
+ }
+
+ if (strcmp (name, AVAHI_DBUS_NAME) < 0) {
+ if (old == NULL && new != NULL) {
+ fprintf(stderr, "Avahi Daemon reconnected\n");
+ } else if (old != NULL && new == NULL) {
+ fprintf(stderr, "Avahi Daemon disconnected\n");
+ }
+ }
+
+ return DBUS_HANDLER_RESULT_HANDLED;
+ }
+
+out:
+ return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
+}
+
+static int _dbus_add_match (DBusConnection *bus, char *type, char *interface, char *sender, char *path)
+{
+ DBusError error;
+ char *filter;
+
+ g_assert (bus != NULL);
+
+ dbus_error_init (&error);
+ filter = g_strdup_printf ("type='%s', interface='%s', sender='%s', path='%s'", type, interface, sender, path);
+ dbus_bus_add_match (bus, filter, &error);
+ g_free (filter);
+
+ if (dbus_error_is_set (&error))
+ {
+ fprintf (stderr, "Error adding filter match: %s\n", error.message);
+ dbus_error_free (&error);
+ return FALSE;
+ }
+
+ return TRUE;
+}
+
AvahiClient *
avahi_client_new ()
{
AvahiClient *tmp;
+ DBusError error;
tmp = malloc (sizeof (AvahiClient));
+ tmp->priv = malloc (sizeof (AvahiClientPriv));
+
+ g_assert (tmp != NULL);
+ g_assert (tmp->priv != NULL);
+
+ dbus_error_init (&error);
+
+ tmp->priv->bus = dbus_bus_get (DBUS_BUS_SYSTEM, &error);
+
+ dbus_connection_setup_with_g_main (tmp->priv->bus, NULL);
+
+ if (dbus_error_is_set (&error)) {
+ fprintf(stderr, "Error getting system d-bus: %s\n", error.message);
+ dbus_error_free (&error);
+ goto fail;
+ }
+
+ dbus_connection_set_exit_on_disconnect (tmp->priv->bus, FALSE);
+
+ if (!dbus_connection_add_filter (tmp->priv->bus, filter_func, tmp, NULL))
+ {
+ fprintf (stderr, "Failed to add d-bus filter\n");
+ goto fail;
+ }
+
+ if (!_dbus_add_match (tmp->priv->bus, "signal", AVAHI_DBUS_INTERFACE_SERVER, AVAHI_DBUS_NAME, AVAHI_DBUS_PATH_SERVER)) goto fail;
+ if (!_dbus_add_match (tmp->priv->bus, "signal", DBUS_INTERFACE_DBUS, DBUS_SERVICE_DBUS, DBUS_PATH_DBUS)) goto fail;
return tmp;
+
+fail:
+ if (tmp->priv) free (tmp->priv);
+ if (tmp) free (tmp);
+ return NULL;
+}
+
+static char*
+avahi_client_get_string_reply_and_block (AvahiClient *client, char *method, char *param)
+{
+ DBusMessage *message;
+ DBusMessage *reply;
+ DBusError error;
+ char *ret;
+
+ g_assert (client != NULL);
+ g_assert (method != NULL);
+
+ dbus_error_init (&error);
+
+ message = dbus_message_new_method_call (AVAHI_DBUS_NAME, AVAHI_DBUS_PATH_SERVER, AVAHI_DBUS_INTERFACE_SERVER, method);
+ fprintf (stderr, "message = dbus_message_new_method_call (%s, %s, %s, %s)\n", AVAHI_DBUS_NAME, AVAHI_DBUS_PATH_SERVER, AVAHI_DBUS_INTERFACE_SERVER, method);
+
+ if (param != NULL)
+ {
+ if (!dbus_message_append_args (message, DBUS_TYPE_STRING, &param, DBUS_TYPE_INVALID))
+ {
+ fprintf (stderr, "Failed to append string argument to %s message\n", method);
+ return NULL;
+ }
+ }
+
+ reply = dbus_connection_send_with_reply_and_block (client->priv->bus, message, -1, &error);
+
+ if (dbus_error_is_set (&error))
+ {
+ fprintf (stderr, "Error sending %s message: %s\n", method, error.message);
+ dbus_error_free (&error);
+ dbus_message_unref (message);
+ return NULL;
+ }
+
+ if (reply == NULL)
+ {
+ dbus_message_unref (message);
+ fprintf (stderr, "Could not connect to Avahi daemon\n");
+ return NULL;
+ }
+
+ dbus_message_get_args (reply, &error, DBUS_TYPE_STRING, &ret);
+
+ if (dbus_error_is_set (&error))
+ {
+ fprintf (stderr, "Failed to parse %s reply: %s\n", method, error.message);
+ dbus_error_free (&error);
+ return NULL;
+ }
+
+ return ret;
+}
+
+char*
+avahi_client_get_version_string (AvahiClient *client)
+{
+ return avahi_client_get_string_reply_and_block (client, "GetVersionString", NULL);
+}
+
+char*
+avahi_client_get_domain_name (AvahiClient *client)
+{
+ return avahi_client_get_string_reply_and_block (client, "GetDomainName", NULL);
+}
+
+char*
+avahi_client_get_host_name (AvahiClient *client)
+{
+ return avahi_client_get_string_reply_and_block (client, "GetHostName", NULL);
+}
+
+char*
+avahi_client_get_host_name_fqdn (AvahiClient *client)
+{
+ return avahi_client_get_string_reply_and_block (client, "GetHostNameFqdn", NULL);
+}
+
+char*
+avahi_client_get_alternative_host_name (AvahiClient *client, char *host)
+{
+ return avahi_client_get_string_reply_and_block (client, "GetAlternativeHostName", host);
+}
+
+char*
+avahi_client_get_alternative_service_name (AvahiClient *client, char *service)
+{
+ return avahi_client_get_string_reply_and_block (client, "GetAlternativeServiceName", service);
}
diff --git a/avahi-client/client.h b/avahi-client/client.h
index 91f5af5..5b0e910 100644
--- a/avahi-client/client.h
+++ b/avahi-client/client.h
@@ -28,13 +28,34 @@
AVAHI_C_DECL_BEGIN
-typedef struct {
+typedef struct _AvahiClientPriv AvahiClientPriv;
+
+typedef struct _AvahiClient {
int serverid;
+ AvahiClientPriv *priv;
} AvahiClient;
/** Creates a new client instance */
AvahiClient* avahi_client_new ();
+/** Get the version of the server */
+char* avahi_client_get_version_string (AvahiClient*);
+
+/** Get host name */
+char* avahi_client_get_host_name (AvahiClient*);
+
+/** Get domain name */
+char* avahi_client_get_domain_name (AvahiClient*);
+
+/** Get FQDN domain name */
+char* avahi_client_get_host_name_fqdn (AvahiClient*);
+
+/** Get alternative host name for a host name that is taken */
+char* avahi_client_get_alternative_host_name (AvahiClient*, char*);
+
+/** Get alternative service name for a service name that is taken */
+char* avahi_client_get_alternative_service_name (AvahiClient*, char*);
+
AVAHI_C_DECL_END
#endif