The data manager connects/disconnects with services, lists multiple properties
of connman, and sets manager properties. The function get_message is important
as it is used to send any method request to connman, and returns the reply that
several functions use. This file should mainly cover setting global properties
(i.e offlinemode), or handling connections.
---
client/data_manager.c | 250 +++++++++++++++++++++++++++++++++++++++++++++++++
client/data_manager.h | 52 ++++++++++
2 files changed, 302 insertions(+)
create mode 100644 client/data_manager.c
create mode 100644 client/data_manager.h
diff --git a/client/data_manager.c b/client/data_manager.c
new file mode 100644
index 0000000..1ab75bb
--- /dev/null
+++ b/client/data_manager.c
@@ -0,0 +1,250 @@
+/*
+ *
+ * Connection Manager
+ *
+ * Copyright (C) 2012 Intel Corporation. All rights reserved.
+ * it under the terms of the GNU General Public License version 2 as
+ * published by the Free Software Foundation.
+ *
+ * This program 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 General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program; if not, write to the Free Software
+ * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
+ *
+ */
+
+#include <stdio.h>
+#include <stdlib.h>
+#include <stdint.h>
+#include <unistd.h>
+#include <string.h>
+#include <errno.h>
+
+#include <glib.h>
+
+#include "connman.h"
+#include "client/services.h"
+#include "client/technology.h"
+#include "client/data_manager.h"
+#include "gdbus/gdbus.h"
+#include "include/dbus.h"
+
+static void extract_manager_properties(DBusMessage *message)
+{
+ DBusMessageIter iter, array;
+
+ dbus_message_iter_init(message, &iter);
+ dbus_message_iter_recurse(&iter, &array);
+ extract_properties(&array);
+}
+
+int store_proxy_input(DBusConnection *connection, DBusMessage *message,
+ char *name, int num_args, char *argv[])
+{
+ int i, j, k;
+ int error;
+
+ gchar **servers = g_try_malloc(0);
+ gchar **excludes = g_try_malloc(0);
+
+ for (i = 0; strcmp(argv[i+5], "excludes"); i++) {
+ servers = g_try_realloc(servers, (i + 1) * sizeof(char *));
+ if (servers == NULL) {
+ fprintf(stderr, "Could not allocate memory for list\n");
+ return -ENOMEM;
+ }
+ servers[i] = g_strdup(argv[i+5]);
+ /* In case the user doesn't enter "excludes" */
+ if (i + 6 == num_args) {
+ i++;
+ j = 0;
+ goto free_servers;
+ }
+ }
+ for (j = 0; j + (i + 6) != num_args; j++) {
+ excludes = g_try_realloc(excludes, (j + 1) * sizeof(char *));
+ if (excludes == NULL) {
+ fprintf(stderr, "Could not allocate memory for list\n");
+ return -ENOMEM;
+ }
+ excludes[j] = g_strdup(argv[j + (i + 6)]);
+ }
+
+free_servers:
+ error = set_proxy_manual(connection, message, name, servers, excludes,
+ i, j);
+
+ for (k = 0; k < j - 1; k++)
+ g_free(excludes[k]);
+ g_free(excludes);
+
+ for (k = 0; k < i - 1; k++)
+ g_free(servers[k]);
+ g_free(servers);
+
+ if (error != 0)
+ return error;
+ return 0;
+}
+
+int connect_service(DBusConnection *connection, char *name)
+{
+ DBusMessage *message, *message_connect;
+ struct service_data service;
+ char *path;
+ const char *path_name;
+ DBusError err;
+
+ message = get_message(connection, "GetServices");
+ if (message == NULL)
+ return -ENOMEM;
+
+ path_name = find_service(connection, message, name, &service);
+ if (path_name == NULL)
+ return -ENXIO;
+
+ path = g_strdup_printf("/net/connman/service/%s", path_name);
+ message_connect = dbus_message_new_method_call("net.connman", path,
+ "net.connman.Service",
+ "Connect");
+ if (message_connect == NULL)
+ return -ENOMEM;
+
+ dbus_error_init(&err);
+ dbus_connection_send_with_reply_and_block(connection, message_connect,
+ -1, &err);
+
+ if (dbus_error_is_set(&err)) {
+ printf("Connection failed; error: '%s'\n", err.message);
+ return -EINVAL;
+ }
+
+ dbus_connection_send(connection, message_connect, NULL);
+ dbus_connection_flush(connection);
+ dbus_message_unref(message_connect);
+ g_free(path);
+
+ return 0;
+}
+
+int disconnect_service(DBusConnection *connection, char *name)
+{
+ DBusMessage *message, *message_disconnect;
+ struct service_data service;
+ char *path;
+ const char *path_name;
+ DBusError err;
+
+ message = get_message(connection, "GetServices");
+ if (message == NULL)
+ return -ENOMEM;
+
+ path_name = find_service(connection, message, name, &service);
+ if (path_name == NULL)
+ return -ENXIO;
+
+ path = g_strdup_printf("/net/connman/service/%s", path_name);
+ printf("%s\n", path);
+ message_disconnect = dbus_message_new_method_call("net.connman", path,
+ "net.connman.Service",
+ "Disconnect");
+ if (message_disconnect == NULL)
+ return -ENOMEM;
+
+ dbus_error_init(&err);
+ dbus_connection_send_with_reply_and_block(connection,
+ message_disconnect,
+ -1, &err);
+
+ if (dbus_error_is_set(&err)) {
+ printf("Connection failed; error: '%s'\n", err.message);
+ return -EINVAL;
+ }
+
+ dbus_connection_send(connection, message_disconnect, NULL);
+ dbus_connection_flush(connection);
+ dbus_message_unref(message_disconnect);
+ g_free(path);
+
+ return 0;
+}
+
+int set_manager(DBusConnection *connection, char *key, dbus_bool_t value)
+{
+ DBusMessage *message;
+ DBusMessageIter iter;
+
+ message = dbus_message_new_method_call("net.connman", "/",
+ "net.connman.Manager",
+ "SetProperty");
+ if (message == NULL)
+ return -ENOMEM;
+
+ dbus_message_iter_init_append(message, &iter);
+ connman_dbus_property_append_basic(&iter, (const char *) key,
+ DBUS_TYPE_BOOLEAN, &value);
+ dbus_connection_send(connection, message, NULL);
+ dbus_connection_flush(connection);
+ dbus_message_unref(message);
+
+ return 0;
+}
+
+/* Call with any given function we want connman to respond to */
+DBusMessage *get_message(DBusConnection *connection, char *function)
+{
+ DBusMessage *message, *reply;
+ DBusError error;
+
+ message = dbus_message_new_method_call(CONNMAN_SERVICE,
+ CONNMAN_MANAGER_PATH,
+ CONNMAN_MANAGER_INTERFACE,
+ function);
+ if (message == NULL)
+ return NULL;
+
+ dbus_error_init(&error);
+
+ reply = dbus_connection_send_with_reply_and_block(connection,
+ message, -1, &error);
+ if (dbus_error_is_set(&error) == TRUE) {
+ fprintf(stderr, "%s\n", error.message);
+ dbus_error_free(&error);
+ } else if (reply == NULL)
+ fprintf(stderr, "Failed to receive message\n");
+
+ dbus_message_unref(message);
+
+ return reply;
+}
+
+int list_properties(DBusConnection *connection, char *function,
+ char *service_name)
+{
+ DBusMessage *message;
+
+ message = get_message(connection, function);
+ if (message == NULL)
+ return -ENOMEM;
+
+ if (strcmp(function, "GetProperties") == 0)
+ extract_manager_properties(message);
+
+ else if (strcmp(function, "GetServices") == 0 && service_name != NULL)
+ extract_services(message, service_name);
+
+ else if (strcmp(function, "GetServices") == 0 && service_name == NULL)
+ get_services(message);
+
+ else if (strcmp(function, "GetTechnologies") == 0)
+ extract_tech(message);
+
+ dbus_message_unref(message);
+
+ return 0;
+}
+
diff --git a/client/data_manager.h b/client/data_manager.h
new file mode 100644
index 0000000..e5d55a4
--- /dev/null
+++ b/client/data_manager.h
@@ -0,0 +1,52 @@
+/*
+ *
+ * Connection Manager
+ *
+ * Copyright (C) 2012 Intel Corporation. All rights reserved.
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License version 2 as
+ * published by the Free Software Foundation.
+ *
+ * This program 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 General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program; if not, write to the Free Software
+ * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
+ *
+ */
+
+#ifndef __CLIENT_DATA_MANAGER_H
+#define __CLIENT_DATA_MANAGER_H
+
+#include <dbus/dbus.h>
+
+#define SIGNAL_LISTEN_TIMEOUT 10
+#define CONNMAN_MANAGER_PATH "/"
+#define CONNMAN_SERVICE "net.connman"
+
+struct signal_args {
+ DBusConnection *connection;
+ const char *signal_name;
+};
+
+struct proxy_input {
+ char *servers;
+ char *excludes;
+};
+
+DBusMessage *get_message(DBusConnection *connection, char *function);
+int store_proxy_input(DBusConnection *connection, DBusMessage *message,
+ char *name, int num_args, char *argv[]);
+int list_properties(DBusConnection *connection, char *function,
+ char *service_name);
+int connect_service(DBusConnection *connection, char *name);
+int disconnect_service(DBusConnection *connection, char *name);
+int set_manager(DBusConnection *connection, char *key, dbus_bool_t value);
+void listen_for_manager_signal(void *args);
+
+#endif
+
--
1.7.9.5
_______________________________________________
connman mailing list
[email protected]
http://lists.connman.net/listinfo/connman
