1 /*************************************************************************** 2 * CVSID: $Id$ 3 * 4 * hald.c : main startup for HAL daemon 5 * 6 * Copyright (C) 2003 David Zeuthen, <david@fubar.dk> 7 * Copyright (C) 2005 Danny Kukawka, <danny.kukawka@web.de> 8 * 9 * Licensed under the Academic Free License version 2.1 10 * 11 * This program is free software; you can redistribute it and/or modify 12 * it under the terms of the GNU General Public License as published by 13 * the Free Software Foundation; either version 2 of the License, or 14 * (at your option) any later version. 15 * 16 * This program is distributed in the hope that it will be useful, 17 * but WITHOUT ANY WARRANTY; without even the implied warranty of 18 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 19 * GNU General Public License for more details. 20 * 21 * You should have received a copy of the GNU General Public License 22 * along with this program; if not, write to the Free Software 23 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA 24 * 25 **************************************************************************/ 26 27 #ifdef HAVE_CONFIG_H 28 # include <config.h> 29 #endif 30 31 #include <stdio.h> 32 #include <stdlib.h> 33 #include <string.h> 34 #include <unistd.h> 35 #include <getopt.h> 36 #include <pwd.h> 37 #include <stdint.h> 38 #include <sys/stat.h> 39 #include <fcntl.h> 40 #include <errno.h> 41 #include <signal.h> 42 #include <grp.h> 43 #include <syslog.h> 44 45 #include <dbus/dbus.h> 46 #include <dbus/dbus-glib.h> 47 #include <dbus/dbus-glib-lowlevel.h> 48 49 /*#include "master_slave.h"*/ 50 51 #include "logger.h" 52 #include "hald.h" 53 #include "device_store.h" 54 #include "device_info.h" 55 #include "osspec.h" 56 #include "hald_dbus.h" 57 #include "util.h" 58 #include "hald_runner.h" 59 #include "util_helper.h" 60 61 static void delete_pid(void) 62 { 63 unlink(HALD_PID_FILE); 64 } 65 66 /** 67 * @defgroup HalDaemon HAL daemon 68 * @brief The HAL daemon manages persistent device objects available through 69 * a D-BUS network API 70 */ 71 72 static HalDeviceStore *global_device_list = NULL; 73 74 static HalDeviceStore *temporary_device_list = NULL; 75 76 77 static void 78 addon_terminated (HalDevice *device, guint32 exit_type, 79 gint return_code, gchar **error, 80 gpointer data1, gpointer data2) 81 { 82 HAL_INFO (("in addon_terminated for udi=%s", device->udi)); 83 84 /* TODO: log to syslog - addons shouldn't just terminate, this is a bug with the addon */ 85 86 /* however, the world can stop, mark this addon as ready 87 * (TODO: potential bug if the addon crashed after calling libhal_device_addon_is_ready()) 88 */ 89 if (hal_device_inc_num_ready_addons (device)) { 90 if (hal_device_are_all_addons_ready (device)) { 91 manager_send_signal_device_added (device); 92 } 93 } 94 } 95 96 97 98 99 static void 100 gdl_store_changed (HalDeviceStore *store, HalDevice *device, 101 gboolean is_added, gpointer user_data) 102 { 103 if (is_added) { 104 GSList *addons; 105 106 HAL_INFO (("Added device to GDL; udi=%s", hal_device_get_udi(device))); 107 108 if ((addons = hal_device_property_get_strlist (device, "info.addons")) != NULL) { 109 GSList *i; 110 111 for (i = addons; i != NULL; i = g_slist_next (i)) { 112 const gchar *command_line; 113 gchar *extra_env[2] = {"HALD_ACTION=addon", NULL}; 114 115 command_line = (const gchar *) i->data; 116 if (hald_runner_start(device, command_line, extra_env, addon_terminated, NULL, NULL)) { 117 HAL_INFO (("Started addon %s for udi %s", 118 command_line, hal_device_get_udi(device))); 119 hal_device_inc_num_addons (device); 120 } else { 121 HAL_ERROR (("Cannot start addon %s for udi %s", 122 command_line, hal_device_get_udi(device))); 123 } 124 } 125 } 126 } else { 127 HAL_INFO (("Removed device from GDL; udi=%s", hal_device_get_udi(device))); 128 hald_runner_kill_device(device); 129 } 130 131 /*hal_device_print (device);*/ 132 133 if (is_added) { 134 if (hal_device_are_all_addons_ready (device)) { 135 manager_send_signal_device_added (device); 136 } 137 } else { 138 if (hal_device_are_all_addons_ready (device)) { 139 manager_send_signal_device_removed (device); 140 } 141 } 142 } 143 144 static void 145 gdl_property_changed (HalDeviceStore *store, HalDevice *device, 146 const char *key, gboolean added, gboolean removed, 147 gpointer user_data) 148 { 149 if (hal_device_are_all_addons_ready (device)) { 150 device_send_signal_property_modified (device, key, removed, added); 151 } 152 153 /* only execute the callouts if the property _changed_ */ 154 if (added == FALSE && removed == FALSE) 155 /*hal_callout_property (device, key)*/; 156 } 157 158 static void 159 gdl_capability_added (HalDeviceStore *store, HalDevice *device, 160 const char *capability, gpointer user_data) 161 { 162 if (hal_device_are_all_addons_ready (device)) { 163 manager_send_signal_new_capability (device, capability); 164 } 165 /*hal_callout_capability (device, capability, TRUE)*/; 166 } 167 168 HalDeviceStore * 169 hald_get_gdl (void) 170 { 171 if (global_device_list == NULL) { 172 global_device_list = hal_device_store_new (); 173 174 g_signal_connect (global_device_list, 175 "store_changed", 176 G_CALLBACK (gdl_store_changed), NULL); 177 g_signal_connect (global_device_list, 178 "device_property_changed", 179 G_CALLBACK (gdl_property_changed), NULL); 180 g_signal_connect (global_device_list, 181 "device_capability_added", 182 G_CALLBACK (gdl_capability_added), NULL); 183 } 184 185 return global_device_list; 186 } 187 188 HalDeviceStore * 189 hald_get_tdl (void) 190 { 191 if (temporary_device_list == NULL) { 192 temporary_device_list = hal_device_store_new (); 193 194 } 195 196 return temporary_device_list; 197 } 198 199 /** 200 * @defgroup MainDaemon Basic functions 201 * @ingroup HalDaemon 202 * @brief Basic functions in the HAL daemon 203 * @{ 204 */ 205 206 /** Print out program usage. 207 * 208 */ 209 static void 210 usage () 211 { 212 fprintf (stderr, "\n" "usage : hald [--daemon=yes|no] [--verbose=yes|no] [--help]\n"); 213 fprintf (stderr, 214 "\n" 215 " --daemon=yes|no Become a daemon\n" 216 " --verbose=yes|no Print out debug (overrides HALD_VERBOSE)\n" 217 " --use-syslog Print out debug messages to syslog instead of stderr.\n" 218 " Use this option to get debug messages if HAL runs as\n" 219 " daemon.\n" 220 " --help Show this information and exit\n" 221 " --version Output version information and exit" 222 "\n" 223 "The HAL daemon detects devices present in the system and provides the\n" 224 "org.freedesktop.Hal service through the system-wide message bus provided\n" 225 "by D-BUS.\n" 226 "\n" 227 "For more information visit http://freedesktop.org/Software/hal\n" 228 "\n"); 229 } 230 231 /** If #TRUE, we will daemonize */ 232 static dbus_bool_t opt_become_daemon = TRUE; 233 234 /** If #TRUE, we will spew out debug */ 235 dbus_bool_t hald_is_verbose = FALSE; 236 dbus_bool_t hald_use_syslog = FALSE; 237 238 static int sigterm_unix_signal_pipe_fds[2]; 239 static GIOChannel *sigterm_iochn; 240 241 static void 242 handle_sigterm (int value) 243 { 244 ssize_t written; 245 static char marker[1] = {'S'}; 246 247 /* write a 'S' character to the other end to tell about 248 * the signal. Note that 'the other end' is a GIOChannel thingy 249 * that is only called from the mainloop - thus this is how we 250 * defer this since UNIX signal handlers are evil 251 * 252 * Oh, and write(2) is indeed reentrant */ 253 written = write (sigterm_unix_signal_pipe_fds[1], marker, 1); 254 } 255 256 static gboolean 257 sigterm_iochn_data (GIOChannel *source, 258 GIOCondition condition, 259 gpointer user_data) 260 { 261 GError *err = NULL; 262 gchar data[1]; 263 gsize bytes_read; 264 265 /* Empty the pipe */ 266 if (G_IO_STATUS_NORMAL != 267 g_io_channel_read_chars (source, data, 1, &bytes_read, &err)) { 268 HAL_ERROR (("Error emptying sigterm pipe: %s", 269 err->message)); 270 g_error_free (err); 271 goto out; 272 } 273 274 HAL_INFO (("Caught SIGTERM, initiating shutdown")); 275 hald_runner_kill_all(); 276 exit (0); 277 278 out: 279 return TRUE; 280 } 281 282 283 /** This is set to #TRUE if we are probing and #FALSE otherwise */ 284 dbus_bool_t hald_is_initialising; 285 286 static int startup_daemonize_pipe[2]; 287 288 289 /*--------------------------------------------------------------------------------------------------*/ 290 291 static gboolean child_died = FALSE; 292 293 static void 294 handle_sigchld (int value) 295 { 296 child_died = TRUE; 297 } 298 299 static int 300 parent_wait_for_child (int child_fd, pid_t child_pid) 301 { 302 fd_set rfds; 303 fd_set efds; 304 struct timeval tv; 305 int retval; 306 int ret; 307 308 signal(SIGCHLD, handle_sigchld); 309 310 /* wait for either 311 * 312 * o Child writes something to the child_fd; means that device 313 * probing is completed and the parent should exit with success 314 * 315 * o Child is killed (segfault etc.); means that parent should exit 316 * with failure 317 * 318 * o Timeout; means that we should kill the child and exit with 319 * failure 320 * 321 */ 322 323 FD_ZERO(&rfds); 324 FD_SET(child_fd, &rfds); 325 FD_ZERO(&efds); 326 FD_SET(child_fd, &efds); 327 /* Wait up to 250 seconds for device probing */ 328 tv.tv_sec = 250; 329 tv.tv_usec = 0; 330 331 retval = select (child_fd + 1, &rfds, NULL, &efds, &tv); 332 333 if (child_died) { 334 /* written from handle_sigchld */ 335 ret = 1; 336 goto out; 337 } 338 339 if (retval > 0) { 340 /* means child wrote to socket or closed it; all good */ 341 ret = 0; 342 goto out; 343 } 344 345 /* assume timeout; kill child */ 346 kill (child_pid, SIGTERM); 347 ret = 2; 348 349 out: 350 return ret; 351 } 352 353 /*--------------------------------------------------------------------------------------------------*/ 354 355 /** Entry point for HAL daemon 356 * 357 * @param argc Number of arguments 358 * @param argv Array of arguments 359 * @return Exit code 360 */ 361 int 362 main (int argc, char *argv[]) 363 { 364 GMainLoop *loop; 365 guint sigterm_iochn_listener_source_id; 366 char *path; 367 char newpath[512]; 368 369 openlog ("hald", LOG_PID, LOG_DAEMON); 370 371 g_type_init (); 372 373 if (getenv ("HALD_VERBOSE")) 374 hald_is_verbose = TRUE; 375 else 376 hald_is_verbose = FALSE; 377 378 /* our helpers are installed into libexec, so adjust out $PATH 379 * to include this at the end (since we want to overide in 380 * run-hald.sh and friends) 381 */ 382 path = getenv ("PATH"); 383 if (path != NULL) { 384 g_strlcpy (newpath, path, sizeof (newpath)); 385 g_strlcat (newpath, ":", sizeof (newpath)); 386 } else { 387 /* No PATH was set */ 388 newpath[0] = '\0'; 389 } 390 391 g_strlcat (newpath, PACKAGE_LIBEXEC_DIR, sizeof (newpath)); 392 g_strlcat (newpath, ":", sizeof (newpath)); 393 g_strlcat (newpath, PACKAGE_SCRIPT_DIR, sizeof (newpath)); 394 395 setenv ("PATH", newpath, TRUE); 396 397 while (1) { 398 int c; 399 int option_index = 0; 400 const char *opt; 401 static struct option long_options[] = { 402 {"daemon", 1, NULL, 0}, 403 {"verbose", 1, NULL, 0}, 404 {"use-syslog", 0, NULL, 0}, 405 {"help", 0, NULL, 0}, 406 {"version", 0, NULL, 0}, 407 {NULL, 0, NULL, 0} 408 }; 409 410 c = getopt_long (argc, argv, "", 411 long_options, &option_index); 412 if (c == -1) 413 break; 414 415 switch (c) { 416 case 0: 417 opt = long_options[option_index].name; 418 419 if (strcmp (opt, "help") == 0) { 420 usage (); 421 return 0; 422 } else if (strcmp (opt, "version") == 0) { 423 fprintf (stderr, "HAL package version: " PACKAGE_VERSION "\n"); 424 return 0; 425 } else if (strcmp (opt, "daemon") == 0) { 426 if (strcmp ("yes", optarg) == 0) { 427 opt_become_daemon = TRUE; 428 } else if (strcmp ("no", optarg) == 0) { 429 opt_become_daemon = FALSE; 430 } else { 431 usage (); 432 return 1; 433 } 434 } else if (strcmp (opt, "verbose") == 0) { 435 if (strcmp ("yes", optarg) == 0) { 436 hald_is_verbose = TRUE; 437 } else if (strcmp ("no", optarg) == 0) { 438 hald_is_verbose = FALSE; 439 } else { 440 usage (); 441 return 1; 442 } 443 } else if (strcmp (opt, "use-syslog") == 0) { 444 hald_use_syslog = TRUE; 445 } 446 447 break; 448 449 default: 450 usage (); 451 return 1; 452 break; 453 } 454 } 455 456 if (hald_is_verbose) 457 logger_enable (); 458 else 459 logger_disable (); 460 461 if (hald_use_syslog) 462 logger_enable_syslog (); 463 else 464 logger_disable_syslog (); 465 466 /* will fork into two; only the child will return here if we are successful */ 467 /*master_slave_setup (); 468 sleep (100000000);*/ 469 470 loop = g_main_loop_new (NULL, FALSE); 471 472 HAL_INFO ((PACKAGE_STRING)); 473 474 if (opt_become_daemon) { 475 int child_pid; 476 int dev_null_fd; 477 int pf; 478 ssize_t written; 479 char pid[9]; 480 481 HAL_INFO (("Will daemonize")); 482 HAL_INFO (("Becoming a daemon")); 483 484 if (pipe (startup_daemonize_pipe) != 0) { 485 fprintf (stderr, "Could not setup pipe: %s\n", strerror(errno)); 486 exit (1); 487 } 488 489 490 if (chdir ("/") < 0) { 491 fprintf (stderr, "Could not chdir to /: %s\n", strerror(errno)); 492 exit (1); 493 } 494 495 child_pid = fork (); 496 switch (child_pid) { 497 case -1: 498 fprintf (stderr, "Cannot fork(): %s\n", strerror(errno)); 499 break; 500 501 case 0: 502 /* child */ 503 504 dev_null_fd = open ("/dev/null", O_RDWR); 505 /* ignore if we can't open /dev/null */ 506 if (dev_null_fd >= 0) { 507 /* attach /dev/null to stdout, stdin, stderr */ 508 dup2 (dev_null_fd, 0); 509 dup2 (dev_null_fd, 1); 510 dup2 (dev_null_fd, 2); 511 close (dev_null_fd); 512 } 513 514 umask (022); 515 break; 516 517 default: 518 /* parent, block until child writes */ 519 exit (parent_wait_for_child (startup_daemonize_pipe[0], child_pid)); 520 break; 521 } 522 523 /* Create session */ 524 setsid (); 525 526 /* remove old pid file */ 527 unlink (HALD_PID_FILE); 528 529 /* Make a new one */ 530 if ((pf= open (HALD_PID_FILE, O_WRONLY|O_CREAT|O_TRUNC|O_EXCL, 0644)) > 0) { 531 snprintf (pid, sizeof(pid), "%lu\n", (long unsigned) getpid ()); 532 written = write (pf, pid, strlen(pid)); 533 close (pf); 534 atexit (delete_pid); 535 } 536 } else { 537 HAL_INFO (("Will not daemonize")); 538 } 539 540 541 /* we need to do stuff when we are expected to terminate, thus 542 * this involves looking for SIGTERM; UNIX signal handlers are 543 * evil though, so set up a pipe to transmit the signal. 544 */ 545 546 /* create pipe */ 547 if (pipe (sigterm_unix_signal_pipe_fds) != 0) { 548 DIE (("Could not setup pipe, errno=%d", errno)); 549 } 550 551 /* setup glib handler - 0 is for reading, 1 is for writing */ 552 sigterm_iochn = g_io_channel_unix_new (sigterm_unix_signal_pipe_fds[0]); 553 if (sigterm_iochn == NULL) 554 DIE (("Could not create GIOChannel")); 555 556 /* get callback when there is data to read */ 557 sigterm_iochn_listener_source_id = g_io_add_watch ( 558 sigterm_iochn, G_IO_IN, sigterm_iochn_data, NULL); 559 560 /* Finally, setup unix signal handler for TERM */ 561 signal (SIGTERM, handle_sigterm); 562 563 /* set up the local dbus server */ 564 if (!hald_dbus_local_server_init ()) 565 return 1; 566 /* Start the runner helper daemon */ 567 if (!hald_runner_start_runner ()) { 568 return 1; 569 } 570 571 drop_privileges(0); 572 573 /* initialize operating system specific parts */ 574 osspec_init (); 575 576 hald_is_initialising = TRUE; 577 578 /* detect devices */ 579 osspec_probe (); 580 581 /* run the main loop and serve clients */ 582 g_main_loop_run (loop); 583 584 return 0; 585 } 586 587 #ifdef HALD_MEMLEAK_DBG 588 extern int dbg_hal_device_object_delta; 589 590 /* useful for valgrinding; see below */ 591 static gboolean 592 my_shutdown (gpointer data) 593 { 594 HalDeviceStore *gdl; 595 596 printf ("Num devices in TDL: %d\n", g_slist_length ((hald_get_tdl ())->devices)); 597 printf ("Num devices in GDL: %d\n", g_slist_length ((hald_get_gdl ())->devices)); 598 599 gdl = hald_get_gdl (); 600 next: 601 if (g_slist_length (gdl->devices) > 0) { 602 HalDevice *d = HAL_DEVICE(gdl->devices->data); 603 hal_device_store_remove (gdl, d); 604 g_object_unref (d); 605 goto next; 606 } 607 608 printf ("hal_device_object_delta = %d (should be zero)\n", dbg_hal_device_object_delta); 609 exit (1); 610 } 611 #endif 612 613 void 614 osspec_probe_done (void) 615 { 616 ssize_t written; 617 char buf[1] = {0}; 618 619 HAL_INFO (("Device probing completed")); 620 621 if (!hald_dbus_init ()) { 622 hald_runner_kill_all(); 623 exit (1); 624 } 625 626 /* tell parent to exit */ 627 written = write (startup_daemonize_pipe[1], buf, sizeof (buf)); 628 close (startup_daemonize_pipe[0]); 629 close (startup_daemonize_pipe[1]); 630 631 hald_is_initialising = FALSE; 632 633 #ifdef HALD_MEMLEAK_DBG 634 g_timeout_add ((HALD_MEMLEAK_DBG) * 1000, 635 my_shutdown, 636 NULL); 637 #endif 638 } 639 640 641 /** @} */ 642