18c2aff776a775d34a4c9893a4c72e0434d68e36artem/***************************************************************************
18c2aff776a775d34a4c9893a4c72e0434d68e36artem * CVSID: $Id$
18c2aff776a775d34a4c9893a4c72e0434d68e36artem * hald_runner.c - Interface to the hal runner helper daemon
18c2aff776a775d34a4c9893a4c72e0434d68e36artem * Copyright (C) 2006 Sjoerd Simons, <sjoerd@luon.net>
18c2aff776a775d34a4c9893a4c72e0434d68e36artem * Licensed under the Academic Free License version 2.1
18c2aff776a775d34a4c9893a4c72e0434d68e36artem * This program is free software; you can redistribute it and/or modify
18c2aff776a775d34a4c9893a4c72e0434d68e36artem * it under the terms of the GNU General Public License as published by
18c2aff776a775d34a4c9893a4c72e0434d68e36artem * the Free Software Foundation; either version 2 of the License, or
18c2aff776a775d34a4c9893a4c72e0434d68e36artem * (at your option) any later version.
18c2aff776a775d34a4c9893a4c72e0434d68e36artem * This program is distributed in the hope that it will be useful,
18c2aff776a775d34a4c9893a4c72e0434d68e36artem * but WITHOUT ANY WARRANTY; without even the implied warranty of
18c2aff776a775d34a4c9893a4c72e0434d68e36artem * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
18c2aff776a775d34a4c9893a4c72e0434d68e36artem * GNU General Public License for more details.
18c2aff776a775d34a4c9893a4c72e0434d68e36artem * You should have received a copy of the GNU General Public License
18c2aff776a775d34a4c9893a4c72e0434d68e36artem * along with this program; if not, write to the Free Software
18c2aff776a775d34a4c9893a4c72e0434d68e36artem * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
18c2aff776a775d34a4c9893a4c72e0434d68e36artem **************************************************************************/
18c2aff776a775d34a4c9893a4c72e0434d68e36artemtypedef struct {
18c2aff776a775d34a4c9893a4c72e0434d68e36artem#define DBUS_SERVER_ADDRESS "unix:tmpdir=" HALD_SOCKET_DIR
18c2aff776a775d34a4c9893a4c72e0434d68e36artemtypedef struct
18c2aff776a775d34a4c9893a4c72e0434d68e36artem/* mapping from PID to RunningProcess */
18c2aff776a775d34a4c9893a4c72e0434d68e36artem g_hash_table_foreach_remove (running_processes, rprd_foreach, device);
18c2aff776a775d34a4c9893a4c72e0434d68e36artemrunner_server_message_handler (DBusConnection *connection,
18c2aff776a775d34a4c9893a4c72e0434d68e36artem /*HAL_INFO (("runner_server_message_handler: destination=%s obj_path=%s interface=%s method=%s",
18c2aff776a775d34a4c9893a4c72e0434d68e36artem dbus_message_get_destination (message),
18c2aff776a775d34a4c9893a4c72e0434d68e36artem dbus_message_get_path (message),
18c2aff776a775d34a4c9893a4c72e0434d68e36artem dbus_message_get_interface (message),
18c2aff776a775d34a4c9893a4c72e0434d68e36artem dbus_message_get_member (message)));*/
18c2aff776a775d34a4c9893a4c72e0434d68e36artem "org.freedesktop.HalRunner",
18c2aff776a775d34a4c9893a4c72e0434d68e36artem "StartedProcessExited")) {
18c2aff776a775d34a4c9893a4c72e0434d68e36artem /*HAL_INFO (("Previously started process with pid %d exited", pid));*/
18c2aff776a775d34a4c9893a4c72e0434d68e36artem rp = g_hash_table_lookup (running_processes, (gpointer) pid);
18c2aff776a775d34a4c9893a4c72e0434d68e36artem rp->cb (rp->device, 0, 0, NULL, rp->data1, rp->data2);
18c2aff776a775d34a4c9893a4c72e0434d68e36artem g_hash_table_remove (running_processes, (gpointer) pid);
18c2aff776a775d34a4c9893a4c72e0434d68e36artemrunner_server_unregister_handler (DBusConnection *connection, void *user_data)
18c2aff776a775d34a4c9893a4c72e0434d68e36artem DBusObjectPathVTable vtable = { &runner_server_unregister_handler,
18c2aff776a775d34a4c9893a4c72e0434d68e36artem dbus_connection_setup_with_g_main (new_connection, NULL);
18c2aff776a775d34a4c9893a4c72e0434d68e36artem /* dbus_server_unref(server); */
18c2aff776a775d34a4c9893a4c72e0434d68e36artem running_processes = g_hash_table_new (g_direct_hash, g_direct_equal);
18c2aff776a775d34a4c9893a4c72e0434d68e36artem server = dbus_server_listen(DBUS_SERVER_ADDRESS, &err);
18c2aff776a775d34a4c9893a4c72e0434d68e36artem HAL_ERROR (("Cannot create D-BUS server for the runner"));
18c2aff776a775d34a4c9893a4c72e0434d68e36artem dbus_server_set_new_connection_function(server, handle_connection,
18c2aff776a775d34a4c9893a4c72e0434d68e36artem env[0] = g_strdup_printf("HALD_RUNNER_DBUS_ADDRESS=%s", server_addr);
18c2aff776a775d34a4c9893a4c72e0434d68e36artem env[1] = g_strdup_printf ("PATH=%s:" PACKAGE_LIBEXEC_DIR ":" PACKAGE_SCRIPT_DIR ":" PACKAGE_BIN_DIR, hald_runner_path);
18c2aff776a775d34a4c9893a4c72e0434d68e36artem env[1] = g_strdup_printf ("PATH=" PACKAGE_LIBEXEC_DIR ":" PACKAGE_SCRIPT_DIR ":" PACKAGE_BIN_DIR);
18c2aff776a775d34a4c9893a4c72e0434d68e36artem /*env[2] = "DBUS_VERBOSE=1";*/
18c2aff776a775d34a4c9893a4c72e0434d68e36artem if (!g_spawn_async(NULL, argv, env, G_SPAWN_DO_NOT_REAP_CHILD|G_SPAWN_SEARCH_PATH,
18c2aff776a775d34a4c9893a4c72e0434d68e36artem HAL_ERROR (("Could not spawn runner : '%s'", error->message));
18c2aff776a775d34a4c9893a4c72e0434d68e36artem /* Wait for the runner */
18c2aff776a775d34a4c9893a4c72e0434d68e36artemadd_property_to_msg (HalDevice *device, HalProperty *property,
18c2aff776a775d34a4c9893a4c72e0434d68e36artem prop_upper = g_ascii_strup (hal_property_get_key (property), -1);
18c2aff776a775d34a4c9893a4c72e0434d68e36artem /* periods aren't valid in the environment, so replace them with
18c2aff776a775d34a4c9893a4c72e0434d68e36artem * underscores. */
18c2aff776a775d34a4c9893a4c72e0434d68e36artem for (c = prop_upper; *c; c++) {
18c2aff776a775d34a4c9893a4c72e0434d68e36artem if (*c == '.')
18c2aff776a775d34a4c9893a4c72e0434d68e36artem env = g_strdup_printf ("HAL_PROP_%s=%s", prop_upper, value);
18c2aff776a775d34a4c9893a4c72e0434d68e36artem dbus_message_iter_append_basic(iter, DBUS_TYPE_STRING, &env);
18c2aff776a775d34a4c9893a4c72e0434d68e36artemadd_env(DBusMessageIter *iter, const gchar *key, const gchar *value) {
18c2aff776a775d34a4c9893a4c72e0434d68e36artem dbus_message_iter_append_basic(iter, DBUS_TYPE_STRING, &env);
18c2aff776a775d34a4c9893a4c72e0434d68e36artemadd_basic_env(DBusMessageIter *iter, const gchar *udi) {
18c2aff776a775d34a4c9893a4c72e0434d68e36artem dbus_message_iter_append_basic(iter, DBUS_TYPE_STRING, &env[i]);
18c2aff776a775d34a4c9893a4c72e0434d68e36artemadd_command(DBusMessageIter *iter, const gchar *command_line) {
18c2aff776a775d34a4c9893a4c72e0434d68e36artem if (!g_shell_parse_argv(command_line, &argc, &argv, &err)) {
18c2aff776a775d34a4c9893a4c72e0434d68e36artem dbus_message_iter_append_basic(&array_iter, DBUS_TYPE_STRING, &argv[x]);
18c2aff776a775d34a4c9893a4c72e0434d68e36artemadd_first_part(DBusMessageIter *iter, HalDevice *device,
18c2aff776a775d34a4c9893a4c72e0434d68e36artem dbus_message_iter_append_basic(iter, DBUS_TYPE_STRING, &udi);
18c2aff776a775d34a4c9893a4c72e0434d68e36artem hal_device_property_foreach (device, add_property_to_msg, &array_iter);
18c2aff776a775d34a4c9893a4c72e0434d68e36artem/* Start a helper, returns true on a successfull start */
18c2aff776a775d34a4c9893a4c72e0434d68e36artemhald_runner_start (HalDevice *device, const gchar *command_line, char **extra_env,
18c2aff776a775d34a4c9893a4c72e0434d68e36artem HalRunTerminatedCB cb, gpointer data1, gpointer data2)
18c2aff776a775d34a4c9893a4c72e0434d68e36artem msg = dbus_message_new_method_call("org.freedesktop.HalRunner",
18c2aff776a775d34a4c9893a4c72e0434d68e36artem "org.freedesktop.HalRunner",
18c2aff776a775d34a4c9893a4c72e0434d68e36artem if (!add_first_part(&iter, device, command_line, extra_env))
18c2aff776a775d34a4c9893a4c72e0434d68e36artem /* Wait for the reply, should be almost instantanious */
18c2aff776a775d34a4c9893a4c72e0434d68e36artem dbus_connection_send_with_reply_and_block(runner_connection,
18c2aff776a775d34a4c9893a4c72e0434d68e36artem (dbus_message_get_type(reply) == DBUS_MESSAGE_TYPE_METHOD_RETURN);
18c2aff776a775d34a4c9893a4c72e0434d68e36artem g_hash_table_insert (running_processes, (gpointer) rp->pid, rp);
18c2aff776a775d34a4c9893a4c72e0434d68e36artem HAL_ERROR (("Error extracting out_pid from runner's Start()"));
18c2aff776a775d34a4c9893a4c72e0434d68e36artem if (dbus_message_get_type(m) != DBUS_MESSAGE_TYPE_METHOD_RETURN)
18c2aff776a775d34a4c9893a4c72e0434d68e36artem dbus_message_iter_get_arg_type(&iter) != DBUS_TYPE_UINT32)
18c2aff776a775d34a4c9893a4c72e0434d68e36artem dbus_message_iter_get_arg_type(&iter) != DBUS_TYPE_INT32)
18c2aff776a775d34a4c9893a4c72e0434d68e36artem dbus_message_iter_get_arg_type(&iter) == DBUS_TYPE_STRING) {
18c2aff776a775d34a4c9893a4c72e0434d68e36artem /* Send a Fail callback on malformed messages */
18c2aff776a775d34a4c9893a4c72e0434d68e36artem HAL_ERROR (("Malformed or unexpected reply message"));
18c2aff776a775d34a4c9893a4c72e0434d68e36artem hb->cb(hb->d, HALD_RUN_FAILED, return_code, NULL, hb->data1, hb->data2);
18c2aff776a775d34a4c9893a4c72e0434d68e36artem/* Run a helper program using the commandline, with input as infomation on
18c2aff776a775d34a4c9893a4c72e0434d68e36artem msg = dbus_message_new_method_call("org.freedesktop.HalRunner",
18c2aff776a775d34a4c9893a4c72e0434d68e36artem "org.freedesktop.HalRunner",
18c2aff776a775d34a4c9893a4c72e0434d68e36artem if (!add_first_part(&iter, device, command_line, extra_env))
18c2aff776a775d34a4c9893a4c72e0434d68e36artem dbus_message_iter_append_basic(&iter, DBUS_TYPE_STRING, &input);
18c2aff776a775d34a4c9893a4c72e0434d68e36artem dbus_message_iter_append_basic(&iter, DBUS_TYPE_BOOLEAN, &error_on_stderr);
18c2aff776a775d34a4c9893a4c72e0434d68e36artem dbus_message_iter_append_basic(&iter, DBUS_TYPE_UINT32, &timeout);
18c2aff776a775d34a4c9893a4c72e0434d68e36artem if (!dbus_connection_send_with_reply(runner_connection,
61155e87dee1493b57ac0b8f9e0a0ba8345b052fXiaolin Zhang - Sun Microsystems - Beijing China /* the connection was disconnected */
61155e87dee1493b57ac0b8f9e0a0ba8345b052fXiaolin Zhang - Sun Microsystems - Beijing China if (call == NULL)
61155e87dee1493b57ac0b8f9e0a0ba8345b052fXiaolin Zhang - Sun Microsystems - Beijing China goto error;
18c2aff776a775d34a4c9893a4c72e0434d68e36artem dbus_pending_call_set_notify(call, call_notify, hd, free);
18c2aff776a775d34a4c9893a4c72e0434d68e36artem hald_runner_run_method(device, command_line, extra_env,
18c2aff776a775d34a4c9893a4c72e0434d68e36artem msg = dbus_message_new_method_call("org.freedesktop.HalRunner",
18c2aff776a775d34a4c9893a4c72e0434d68e36artem "org.freedesktop.HalRunner",
18c2aff776a775d34a4c9893a4c72e0434d68e36artem dbus_message_iter_append_basic(&iter, DBUS_TYPE_STRING, &udi);
18c2aff776a775d34a4c9893a4c72e0434d68e36artem /* Wait for the reply, should be almost instantanious */
18c2aff776a775d34a4c9893a4c72e0434d68e36artem dbus_connection_send_with_reply_and_block(runner_connection, msg, -1, &err);
18c4e255539c8eac2a18c73be8729ec1f6fa818aLin Guo - Sun Microsystems /* hald_runner has not yet started, just return */
18c2aff776a775d34a4c9893a4c72e0434d68e36artem msg = dbus_message_new_method_call("org.freedesktop.HalRunner",
18c2aff776a775d34a4c9893a4c72e0434d68e36artem "org.freedesktop.HalRunner",
18c2aff776a775d34a4c9893a4c72e0434d68e36artem "KillAll");
18c2aff776a775d34a4c9893a4c72e0434d68e36artem /* Wait for the reply, should be almost instantanious */