| /* |
| * |
| * Wireless daemon for Linux |
| * |
| * Copyright (C) 2013-2014 Intel Corporation. All rights reserved. |
| * |
| * 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 <unistd.h> |
| #include <stdio.h> |
| |
| #include <ell/ell.h> |
| #include <ell/dbus-private.h> |
| #include "src/dbus.h" |
| #include "src/agent.h" |
| #include "src/iwd.h" |
| |
| struct l_dbus *g_dbus = 0; |
| |
| static void do_debug(const char *str, void *user_data) |
| { |
| const char *prefix = user_data; |
| |
| l_info("%s%s", prefix, str); |
| } |
| |
| void dbus_dict_append_string(struct l_dbus_message_builder *builder, |
| const char *key, const char *strval) |
| { |
| l_dbus_message_builder_enter_dict(builder, "sv"); |
| l_dbus_message_builder_append_basic(builder, 's', key); |
| l_dbus_message_builder_enter_variant(builder, "s"); |
| l_dbus_message_builder_append_basic(builder, 's', strval); |
| l_dbus_message_builder_leave_variant(builder); |
| l_dbus_message_builder_leave_dict(builder); |
| } |
| |
| void dbus_dict_append_bool(struct l_dbus_message_builder *builder, |
| const char *key, bool boolval) |
| { |
| l_dbus_message_builder_enter_dict(builder, "sv"); |
| l_dbus_message_builder_append_basic(builder, 's', key); |
| l_dbus_message_builder_enter_variant(builder, "b"); |
| l_dbus_message_builder_append_basic(builder, 'b', &boolval); |
| l_dbus_message_builder_leave_variant(builder); |
| l_dbus_message_builder_leave_dict(builder); |
| } |
| |
| void dbus_dict_append_object(struct l_dbus_message_builder *builder, |
| const char *key, const char *object_path) |
| { |
| l_dbus_message_builder_enter_dict(builder, "sv"); |
| l_dbus_message_builder_append_basic(builder, 's', key); |
| l_dbus_message_builder_enter_variant(builder, "o"); |
| l_dbus_message_builder_append_basic(builder, 'o', object_path); |
| l_dbus_message_builder_leave_variant(builder); |
| l_dbus_message_builder_leave_dict(builder); |
| } |
| |
| void dbus_dict_append_bytearray(struct l_dbus_message_builder *builder, |
| const char *key, const uint8_t *arrayval, |
| const int len) |
| { |
| int i; |
| |
| l_dbus_message_builder_enter_dict(builder, "sv"); |
| l_dbus_message_builder_append_basic(builder, 's', key); |
| l_dbus_message_builder_enter_variant(builder, "ay"); |
| l_dbus_message_builder_enter_array(builder, "y"); |
| |
| for (i = 0; i < len; i++) |
| l_dbus_message_builder_append_basic(builder, 'y', &arrayval[i]); |
| |
| l_dbus_message_builder_leave_array(builder); |
| l_dbus_message_builder_leave_variant(builder); |
| l_dbus_message_builder_leave_dict(builder); |
| } |
| |
| struct l_dbus_message *dbus_error_busy(struct l_dbus_message *msg) |
| { |
| return l_dbus_message_new_error(msg, IWD_SERVICE ".InProgress", |
| "Operation already in progress"); |
| } |
| |
| struct l_dbus_message *dbus_error_failed(struct l_dbus_message *msg) |
| { |
| return l_dbus_message_new_error(msg, IWD_SERVICE ".Failed", |
| "Operation failed"); |
| } |
| |
| struct l_dbus_message *dbus_error_aborted(struct l_dbus_message *msg) |
| { |
| return l_dbus_message_new_error(msg, IWD_SERVICE ".Aborted", |
| "Operation aborted"); |
| } |
| |
| struct l_dbus_message *dbus_error_not_available(struct l_dbus_message *msg) |
| { |
| return l_dbus_message_new_error(msg, IWD_SERVICE ".NotAvailable", |
| "Operation not available"); |
| } |
| |
| struct l_dbus_message *dbus_error_invalid_args(struct l_dbus_message *msg) |
| { |
| return l_dbus_message_new_error(msg, IWD_SERVICE ".InvalidArgs", |
| "Argument type is wrong"); |
| } |
| |
| struct l_dbus_message *dbus_error_invalid_format(struct l_dbus_message *msg) |
| { |
| return l_dbus_message_new_error(msg, IWD_SERVICE ".InvalidFormat", |
| "Argument format is invalid"); |
| } |
| |
| struct l_dbus_message *dbus_error_already_exists(struct l_dbus_message *msg) |
| { |
| return l_dbus_message_new_error(msg, IWD_SERVICE ".AlreadyExists", |
| "Object already exists"); |
| } |
| |
| struct l_dbus_message *dbus_error_not_found(struct l_dbus_message *msg) |
| { |
| return l_dbus_message_new_error(msg, IWD_SERVICE ".NotFound", |
| "Object not found"); |
| } |
| |
| struct l_dbus_message *dbus_error_not_supported(struct l_dbus_message *msg) |
| { |
| return l_dbus_message_new_error(msg, IWD_SERVICE ".NotSupported", |
| "Operation not supported"); |
| } |
| |
| struct l_dbus_message *dbus_error_no_agent(struct l_dbus_message *msg) |
| { |
| return l_dbus_message_new_error(msg, IWD_SERVICE ".NoAgent", |
| "No Agent registered"); |
| } |
| |
| struct l_dbus_message *dbus_error_not_connected(struct l_dbus_message *msg) |
| { |
| return l_dbus_message_new_error(msg, IWD_SERVICE ".NotConnected", |
| "Not connected"); |
| } |
| |
| struct l_dbus_message *dbus_error_not_configured(struct l_dbus_message *msg) |
| { |
| return l_dbus_message_new_error(msg, IWD_SERVICE ".NotConfigured", |
| "Not configured"); |
| } |
| |
| struct l_dbus_message *dbus_error_not_implemented(struct l_dbus_message *msg) |
| { |
| return l_dbus_message_new_error(msg, IWD_SERVICE ".NotImplemented", |
| "Not implemented"); |
| } |
| |
| void dbus_pending_reply(struct l_dbus_message **msg, |
| struct l_dbus_message *reply) |
| { |
| struct l_dbus *dbus = dbus_get_bus(); |
| |
| l_dbus_send(dbus, reply); |
| l_dbus_message_unref(*msg); |
| *msg = NULL; |
| } |
| |
| static void request_name_callback(struct l_dbus *dbus, bool success, |
| bool queued, void *user_data) |
| { |
| if (!success) |
| l_error("Name request failed"); |
| } |
| |
| static void ready_callback(void *user_data) |
| { |
| l_dbus_name_acquire(g_dbus, "net.connman.iwd", false, false, true, |
| request_name_callback, NULL); |
| |
| if (!l_dbus_object_manager_enable(g_dbus)) |
| l_info("Unable to register the ObjectManager"); |
| |
| agent_init(g_dbus); |
| } |
| |
| static void disconnect_callback(void *user_data) |
| { |
| l_info("D-Bus disconnected, quitting..."); |
| iwd_shutdown(); |
| } |
| |
| struct l_dbus *dbus_get_bus(void) |
| { |
| return g_dbus; |
| } |
| |
| bool dbus_init(bool enable_debug) |
| { |
| g_dbus = l_dbus_new_default(L_DBUS_SYSTEM_BUS); |
| if (!g_dbus) |
| return false; |
| |
| if (enable_debug) |
| l_dbus_set_debug(g_dbus, do_debug, "[DBUS] ", NULL); |
| |
| l_dbus_set_ready_handler(g_dbus, ready_callback, g_dbus, NULL); |
| l_dbus_set_disconnect_handler(g_dbus, disconnect_callback, NULL, NULL); |
| |
| return true; |
| } |
| |
| bool dbus_exit(void) |
| { |
| agent_exit(g_dbus); |
| |
| l_dbus_destroy(g_dbus); |
| g_dbus = NULL; |
| |
| return true; |
| } |
| |
| void dbus_shutdown(void) |
| { |
| /* Allow AgentManager to send a Release call before disconnecting */ |
| agent_shutdown(); |
| } |