X-Git-Url: http://git.ozlabs.org/?p=petitboot;a=blobdiff_plain;f=discover%2Fdevice-handler.c;h=c31fceaf5a11b1ac22c28f50ad530866f4b7f23e;hp=1c69de02e7f85a8f9dfe5166af9d4bb2cbaab95a;hb=58a9dfb65164095f32b1d5f7070015da5111d884;hpb=1a72ffef7837cd2aa3e6be945ec03fb6b5caa51a diff --git a/discover/device-handler.c b/discover/device-handler.c index 1c69de0..c31fcea 100644 --- a/discover/device-handler.c +++ b/discover/device-handler.c @@ -359,6 +359,15 @@ void device_handler_remove(struct device_handler *handler, struct discover_boot_option *opt, *tmp; unsigned int i; + list_for_each_entry_safe(&device->boot_options, opt, tmp, list) { + if (opt == handler->default_boot_option) { + pb_log("Default option %s cancelled since device removed", + opt->option->name); + device_handler_cancel_default(handler); + break; + } + } + for (i = 0; i < handler->n_devices; i++) if (handler->devices[i] == device) break; @@ -708,50 +717,6 @@ struct discover_context *device_handler_discover_context_create( return ctx; } -/** - * context_commit - Commit a temporary discovery context to the handler, - * and notify the clients about any new options / devices - */ -void device_handler_discover_context_commit(struct device_handler *handler, - struct discover_context *ctx) -{ - struct discover_device *dev = ctx->device; - struct discover_boot_option *opt, *tmp; - - if (!device_lookup_by_id(handler, dev->device->id)) - device_handler_add_device(handler, dev); - - /* move boot options from the context to the device */ - list_for_each_entry_safe(&ctx->boot_options, opt, tmp, list) { - list_remove(&opt->list); - - if (boot_option_resolve(opt, handler)) { - pb_log("boot option %s is resolved, " - "sending to clients\n", - opt->option->id); - list_add_tail(&dev->boot_options, &opt->list); - talloc_steal(dev, opt); - boot_option_finalise(handler, opt); - notify_boot_option(handler, opt); - } else { - if (!opt->source->resolve_resource) { - pb_log("parser %s gave us an unresolved " - "resource (%s), but no way to " - "resolve it\n", - opt->source->name, opt->option->id); - talloc_free(opt); - } else { - pb_log("boot option %s is unresolved, " - "adding to queue\n", - opt->option->id); - list_add(&handler->unresolved_boot_options, - &opt->list); - talloc_steal(handler, opt); - } - } - } -} - void device_handler_add_device(struct device_handler *handler, struct discover_device *device) { @@ -905,7 +870,7 @@ out: device_handler_boot_status(handler, status); talloc_free(status); - talloc_free(ctx); + talloc_unlink(handler, ctx); return 0; } @@ -944,7 +909,7 @@ int device_handler_dhcp(struct device_handler *handler, device_handler_boot_status(handler, status); talloc_free(status); - talloc_free(ctx); + talloc_unlink(handler, ctx); return 0; } @@ -974,7 +939,7 @@ int device_handler_conf(struct device_handler *handler, device_handler_boot_status(handler, status); talloc_free(status); - talloc_free(ctx); + talloc_unlink(handler, ctx); return 0; } @@ -1206,7 +1171,7 @@ void device_handler_process_url(struct device_handler *handler, device_handler_discover_context_commit(handler, ctx); - talloc_free(ctx); + talloc_unlink(handler, ctx); status->type = BOOT_STATUS_INFO; status->message = talloc_asprintf(status, _("Config file %s parsed"), @@ -1218,6 +1183,58 @@ msg: #ifndef PETITBOOT_TEST +/** + * context_commit - Commit a temporary discovery context to the handler, + * and notify the clients about any new options / devices + */ +void device_handler_discover_context_commit(struct device_handler *handler, + struct discover_context *ctx) +{ + struct discover_device *dev = ctx->device; + struct discover_boot_option *opt, *tmp; + + if (!device_lookup_by_id(handler, dev->device->id)) + device_handler_add_device(handler, dev); + + /* move boot options from the context to the device */ + list_for_each_entry_safe(&ctx->boot_options, opt, tmp, list) { + list_remove(&opt->list); + + /* All boot options need at least a kernel image */ + if (!opt->boot_image || !opt->boot_image->url) { + pb_log("boot option %s is missing boot image, ignoring\n", + opt->option->id); + talloc_free(opt); + continue; + } + + if (boot_option_resolve(opt, handler)) { + pb_log("boot option %s is resolved, " + "sending to clients\n", + opt->option->id); + list_add_tail(&dev->boot_options, &opt->list); + talloc_steal(dev, opt); + boot_option_finalise(handler, opt); + notify_boot_option(handler, opt); + } else { + if (!opt->source->resolve_resource) { + pb_log("parser %s gave us an unresolved " + "resource (%s), but no way to " + "resolve it\n", + opt->source->name, opt->option->id); + talloc_free(opt); + } else { + pb_log("boot option %s is unresolved, " + "adding to queue\n", + opt->option->id); + list_add(&handler->unresolved_boot_options, + &opt->list); + talloc_steal(handler, opt); + } + } + } +} + static void device_handler_update_lang(const char *lang) { const char *cur_lang; @@ -1564,8 +1581,50 @@ void device_release_write(struct discover_device *dev, bool release) dev->mounted = true; } +void device_sync_snapshots(struct device_handler *handler, const char *device) +{ + struct discover_device *dev = NULL; + unsigned int i; + + if (device) { + /* Find matching device and sync */ + dev = device_lookup_by_name(handler, device); + if (!dev) { + pb_log("%s: device name '%s' unrecognised\n", + __func__, device); + return; + } + if (dev->ramdisk) + device_release_write(dev, true); + else + pb_log("%s has no snapshot to merge, skipping\n", + dev->device->id); + return; + } + + /* Otherwise sync all relevant devices */ + for (i = 0; i < handler->n_devices; i++) { + dev = handler->devices[i]; + if (dev->device->type != DEVICE_TYPE_DISK && + dev->device->type != DEVICE_TYPE_USB) + continue; + if (dev->ramdisk) + device_release_write(dev, true); + else + pb_log("%s has no snapshot to merge, skipping\n", + dev->device->id); + } +} + #else +void device_handler_discover_context_commit( + struct device_handler *handler __attribute__((unused)), + struct discover_context *ctx __attribute__((unused))) +{ + pb_log("%s stubbed out for test cases\n", __func__); +} + static void device_handler_update_lang(const char *lang __attribute__((unused))) { } @@ -1604,5 +1663,10 @@ void device_release_write(struct discover_device *dev __attribute__((unused)), { } -#endif +void device_sync_snapshots( + struct device_handler *handler __attribute__((unused)), + const char *device __attribute__((unused))) +{ +} +#endif