|  | /* | 
|  | * Options Visitor | 
|  | * | 
|  | * Copyright Red Hat, Inc. 2012-2016 | 
|  | * | 
|  | * Author: Laszlo Ersek <lersek@redhat.com> | 
|  | * | 
|  | * This work is licensed under the terms of the GNU LGPL, version 2.1 or later. | 
|  | * See the COPYING.LIB file in the top-level directory. | 
|  | * | 
|  | */ | 
|  |  | 
|  | #include "qemu/osdep.h" | 
|  | #include "qapi/error.h" | 
|  | #include "qemu/cutils.h" | 
|  | #include "qapi/qmp/qerror.h" | 
|  | #include "qapi/opts-visitor.h" | 
|  | #include "qemu/queue.h" | 
|  | #include "qemu/option_int.h" | 
|  | #include "qapi/visitor-impl.h" | 
|  |  | 
|  |  | 
|  | enum ListMode | 
|  | { | 
|  | LM_NONE,             /* not traversing a list of repeated options */ | 
|  |  | 
|  | LM_IN_PROGRESS,      /* | 
|  | * opts_next_list() ready to be called. | 
|  | * | 
|  | * Generating the next list link will consume the most | 
|  | * recently parsed QemuOpt instance of the repeated | 
|  | * option. | 
|  | * | 
|  | * Parsing a value into the list link will examine the | 
|  | * next QemuOpt instance of the repeated option, and | 
|  | * possibly enter LM_SIGNED_INTERVAL or | 
|  | * LM_UNSIGNED_INTERVAL. | 
|  | */ | 
|  |  | 
|  | LM_SIGNED_INTERVAL,  /* | 
|  | * opts_next_list() has been called. | 
|  | * | 
|  | * Generating the next list link will consume the most | 
|  | * recently stored element from the signed interval, | 
|  | * parsed from the most recent QemuOpt instance of the | 
|  | * repeated option. This may consume QemuOpt itself | 
|  | * and return to LM_IN_PROGRESS. | 
|  | * | 
|  | * Parsing a value into the list link will store the | 
|  | * next element of the signed interval. | 
|  | */ | 
|  |  | 
|  | LM_UNSIGNED_INTERVAL, /* Same as above, only for an unsigned interval. */ | 
|  |  | 
|  | LM_TRAVERSED          /* | 
|  | * opts_next_list() has been called. | 
|  | * | 
|  | * No more QemuOpt instance in the list. | 
|  | * The traversal has been completed. | 
|  | */ | 
|  | }; | 
|  |  | 
|  | typedef enum ListMode ListMode; | 
|  |  | 
|  | struct OptsVisitor | 
|  | { | 
|  | Visitor visitor; | 
|  |  | 
|  | /* Ownership remains with opts_visitor_new()'s caller. */ | 
|  | const QemuOpts *opts_root; | 
|  |  | 
|  | unsigned depth; | 
|  |  | 
|  | /* Non-null iff depth is positive. Each key is a QemuOpt name. Each value | 
|  | * is a non-empty GQueue, enumerating all QemuOpt occurrences with that | 
|  | * name. */ | 
|  | GHashTable *unprocessed_opts; | 
|  |  | 
|  | /* The list currently being traversed with opts_start_list() / | 
|  | * opts_next_list(). The list must have a struct element type in the | 
|  | * schema, with a single mandatory scalar member. */ | 
|  | ListMode list_mode; | 
|  | GQueue *repeated_opts; | 
|  |  | 
|  | /* When parsing a list of repeating options as integers, values of the form | 
|  | * "a-b", representing a closed interval, are allowed. Elements in the | 
|  | * range are generated individually. | 
|  | */ | 
|  | union { | 
|  | int64_t s; | 
|  | uint64_t u; | 
|  | } range_next, range_limit; | 
|  |  | 
|  | /* If "opts_root->id" is set, reinstantiate it as a fake QemuOpt for | 
|  | * uniformity. Only its "name" and "str" fields are set. "fake_id_opt" does | 
|  | * not survive or escape the OptsVisitor object. | 
|  | */ | 
|  | QemuOpt *fake_id_opt; | 
|  | }; | 
|  |  | 
|  |  | 
|  | static OptsVisitor *to_ov(Visitor *v) | 
|  | { | 
|  | return container_of(v, OptsVisitor, visitor); | 
|  | } | 
|  |  | 
|  |  | 
|  | static void | 
|  | destroy_list(gpointer list) | 
|  | { | 
|  | g_queue_free(list); | 
|  | } | 
|  |  | 
|  |  | 
|  | static void | 
|  | opts_visitor_insert(GHashTable *unprocessed_opts, const QemuOpt *opt) | 
|  | { | 
|  | GQueue *list; | 
|  |  | 
|  | list = g_hash_table_lookup(unprocessed_opts, opt->name); | 
|  | if (list == NULL) { | 
|  | list = g_queue_new(); | 
|  |  | 
|  | /* GHashTable will never try to free the keys -- we supply NULL as | 
|  | * "key_destroy_func" in opts_start_struct(). Thus cast away key | 
|  | * const-ness in order to suppress gcc's warning. | 
|  | */ | 
|  | g_hash_table_insert(unprocessed_opts, (gpointer)opt->name, list); | 
|  | } | 
|  |  | 
|  | /* Similarly, destroy_list() doesn't call g_queue_free_full(). */ | 
|  | g_queue_push_tail(list, (gpointer)opt); | 
|  | } | 
|  |  | 
|  |  | 
|  | static bool | 
|  | opts_start_struct(Visitor *v, const char *name, void **obj, | 
|  | size_t size, Error **errp) | 
|  | { | 
|  | OptsVisitor *ov = to_ov(v); | 
|  | const QemuOpt *opt; | 
|  |  | 
|  | if (obj) { | 
|  | *obj = g_malloc0(size); | 
|  | } | 
|  | if (ov->depth++ > 0) { | 
|  | return true; | 
|  | } | 
|  |  | 
|  | ov->unprocessed_opts = g_hash_table_new_full(&g_str_hash, &g_str_equal, | 
|  | NULL, &destroy_list); | 
|  | QTAILQ_FOREACH(opt, &ov->opts_root->head, next) { | 
|  | /* ensured by qemu-option.c::opts_do_parse() */ | 
|  | assert(strcmp(opt->name, "id") != 0); | 
|  |  | 
|  | opts_visitor_insert(ov->unprocessed_opts, opt); | 
|  | } | 
|  |  | 
|  | if (ov->opts_root->id != NULL) { | 
|  | ov->fake_id_opt = g_malloc0(sizeof *ov->fake_id_opt); | 
|  |  | 
|  | ov->fake_id_opt->name = g_strdup("id"); | 
|  | ov->fake_id_opt->str = g_strdup(ov->opts_root->id); | 
|  | opts_visitor_insert(ov->unprocessed_opts, ov->fake_id_opt); | 
|  | } | 
|  | return true; | 
|  | } | 
|  |  | 
|  |  | 
|  | static bool | 
|  | opts_check_struct(Visitor *v, Error **errp) | 
|  | { | 
|  | OptsVisitor *ov = to_ov(v); | 
|  | GHashTableIter iter; | 
|  | GQueue *any; | 
|  |  | 
|  | if (ov->depth > 1) { | 
|  | return true; | 
|  | } | 
|  |  | 
|  | /* we should have processed all (distinct) QemuOpt instances */ | 
|  | g_hash_table_iter_init(&iter, ov->unprocessed_opts); | 
|  | if (g_hash_table_iter_next(&iter, NULL, (void **)&any)) { | 
|  | const QemuOpt *first; | 
|  |  | 
|  | first = g_queue_peek_head(any); | 
|  | error_setg(errp, "Invalid parameter '%s'", first->name); | 
|  | return false; | 
|  | } | 
|  | return true; | 
|  | } | 
|  |  | 
|  |  | 
|  | static void | 
|  | opts_end_struct(Visitor *v, void **obj) | 
|  | { | 
|  | OptsVisitor *ov = to_ov(v); | 
|  |  | 
|  | if (--ov->depth > 0) { | 
|  | return; | 
|  | } | 
|  |  | 
|  | g_hash_table_destroy(ov->unprocessed_opts); | 
|  | ov->unprocessed_opts = NULL; | 
|  | if (ov->fake_id_opt) { | 
|  | g_free(ov->fake_id_opt->name); | 
|  | g_free(ov->fake_id_opt->str); | 
|  | g_free(ov->fake_id_opt); | 
|  | } | 
|  | ov->fake_id_opt = NULL; | 
|  | } | 
|  |  | 
|  |  | 
|  | static GQueue * | 
|  | lookup_distinct(const OptsVisitor *ov, const char *name, Error **errp) | 
|  | { | 
|  | GQueue *list; | 
|  |  | 
|  | list = g_hash_table_lookup(ov->unprocessed_opts, name); | 
|  | if (!list) { | 
|  | error_setg(errp, QERR_MISSING_PARAMETER, name); | 
|  | } | 
|  | return list; | 
|  | } | 
|  |  | 
|  |  | 
|  | static bool | 
|  | opts_start_list(Visitor *v, const char *name, GenericList **list, size_t size, | 
|  | Error **errp) | 
|  | { | 
|  | OptsVisitor *ov = to_ov(v); | 
|  |  | 
|  | /* we can't traverse a list in a list */ | 
|  | assert(ov->list_mode == LM_NONE); | 
|  | /* we don't support visits without a list */ | 
|  | assert(list); | 
|  | ov->repeated_opts = lookup_distinct(ov, name, errp); | 
|  | if (!ov->repeated_opts) { | 
|  | *list = NULL; | 
|  | return false; | 
|  | } | 
|  | ov->list_mode = LM_IN_PROGRESS; | 
|  | *list = g_malloc0(size); | 
|  | return true; | 
|  | } | 
|  |  | 
|  |  | 
|  | static GenericList * | 
|  | opts_next_list(Visitor *v, GenericList *tail, size_t size) | 
|  | { | 
|  | OptsVisitor *ov = to_ov(v); | 
|  |  | 
|  | switch (ov->list_mode) { | 
|  | case LM_TRAVERSED: | 
|  | return NULL; | 
|  | case LM_SIGNED_INTERVAL: | 
|  | case LM_UNSIGNED_INTERVAL: | 
|  | if (ov->list_mode == LM_SIGNED_INTERVAL) { | 
|  | if (ov->range_next.s < ov->range_limit.s) { | 
|  | ++ov->range_next.s; | 
|  | break; | 
|  | } | 
|  | } else if (ov->range_next.u < ov->range_limit.u) { | 
|  | ++ov->range_next.u; | 
|  | break; | 
|  | } | 
|  | ov->list_mode = LM_IN_PROGRESS; | 
|  | /* range has been completed, fall through in order to pop option */ | 
|  |  | 
|  | case LM_IN_PROGRESS: { | 
|  | const QemuOpt *opt; | 
|  |  | 
|  | opt = g_queue_pop_head(ov->repeated_opts); | 
|  | if (g_queue_is_empty(ov->repeated_opts)) { | 
|  | g_hash_table_remove(ov->unprocessed_opts, opt->name); | 
|  | ov->repeated_opts = NULL; | 
|  | ov->list_mode = LM_TRAVERSED; | 
|  | return NULL; | 
|  | } | 
|  | break; | 
|  | } | 
|  |  | 
|  | default: | 
|  | abort(); | 
|  | } | 
|  |  | 
|  | tail->next = g_malloc0(size); | 
|  | return tail->next; | 
|  | } | 
|  |  | 
|  |  | 
|  | static bool | 
|  | opts_check_list(Visitor *v, Error **errp) | 
|  | { | 
|  | /* | 
|  | * Unvisited list elements will be reported later when checking | 
|  | * whether unvisited struct members remain. | 
|  | */ | 
|  | return true; | 
|  | } | 
|  |  | 
|  |  | 
|  | static void | 
|  | opts_end_list(Visitor *v, void **obj) | 
|  | { | 
|  | OptsVisitor *ov = to_ov(v); | 
|  |  | 
|  | assert(ov->list_mode == LM_IN_PROGRESS || | 
|  | ov->list_mode == LM_SIGNED_INTERVAL || | 
|  | ov->list_mode == LM_UNSIGNED_INTERVAL || | 
|  | ov->list_mode == LM_TRAVERSED); | 
|  | ov->repeated_opts = NULL; | 
|  | ov->list_mode = LM_NONE; | 
|  | } | 
|  |  | 
|  |  | 
|  | static const QemuOpt * | 
|  | lookup_scalar(const OptsVisitor *ov, const char *name, Error **errp) | 
|  | { | 
|  | if (ov->list_mode == LM_NONE) { | 
|  | GQueue *list; | 
|  |  | 
|  | /* the last occurrence of any QemuOpt takes effect when queried by name | 
|  | */ | 
|  | list = lookup_distinct(ov, name, errp); | 
|  | return list ? g_queue_peek_tail(list) : NULL; | 
|  | } | 
|  | if (ov->list_mode == LM_TRAVERSED) { | 
|  | error_setg(errp, "Fewer list elements than expected"); | 
|  | return NULL; | 
|  | } | 
|  | assert(ov->list_mode == LM_IN_PROGRESS); | 
|  | return g_queue_peek_head(ov->repeated_opts); | 
|  | } | 
|  |  | 
|  |  | 
|  | static void | 
|  | processed(OptsVisitor *ov, const char *name) | 
|  | { | 
|  | if (ov->list_mode == LM_NONE) { | 
|  | g_hash_table_remove(ov->unprocessed_opts, name); | 
|  | return; | 
|  | } | 
|  | assert(ov->list_mode == LM_IN_PROGRESS); | 
|  | /* do nothing */ | 
|  | } | 
|  |  | 
|  |  | 
|  | static bool | 
|  | opts_type_str(Visitor *v, const char *name, char **obj, Error **errp) | 
|  | { | 
|  | OptsVisitor *ov = to_ov(v); | 
|  | const QemuOpt *opt; | 
|  |  | 
|  | opt = lookup_scalar(ov, name, errp); | 
|  | if (!opt) { | 
|  | *obj = NULL; | 
|  | return false; | 
|  | } | 
|  | *obj = g_strdup(opt->str ? opt->str : ""); | 
|  | /* Note that we consume a string even if this is called as part of | 
|  | * an enum visit that later fails because the string is not a | 
|  | * valid enum value; this is harmless because tracking what gets | 
|  | * consumed only matters to visit_end_struct() as the final error | 
|  | * check if there were no other failures during the visit.  */ | 
|  | processed(ov, name); | 
|  | return true; | 
|  | } | 
|  |  | 
|  |  | 
|  | static bool | 
|  | opts_type_bool(Visitor *v, const char *name, bool *obj, Error **errp) | 
|  | { | 
|  | OptsVisitor *ov = to_ov(v); | 
|  | const QemuOpt *opt; | 
|  |  | 
|  | opt = lookup_scalar(ov, name, errp); | 
|  | if (!opt) { | 
|  | return false; | 
|  | } | 
|  | if (opt->str) { | 
|  | if (!qapi_bool_parse(opt->name, opt->str, obj, errp)) { | 
|  | return false; | 
|  | } | 
|  | } else { | 
|  | *obj = true; | 
|  | } | 
|  |  | 
|  | processed(ov, name); | 
|  | return true; | 
|  | } | 
|  |  | 
|  |  | 
|  | static bool | 
|  | opts_type_int64(Visitor *v, const char *name, int64_t *obj, Error **errp) | 
|  | { | 
|  | OptsVisitor *ov = to_ov(v); | 
|  | const QemuOpt *opt; | 
|  | const char *str; | 
|  | long long val; | 
|  | char *endptr; | 
|  |  | 
|  | if (ov->list_mode == LM_SIGNED_INTERVAL) { | 
|  | *obj = ov->range_next.s; | 
|  | return true; | 
|  | } | 
|  |  | 
|  | opt = lookup_scalar(ov, name, errp); | 
|  | if (!opt) { | 
|  | return false; | 
|  | } | 
|  | str = opt->str ? opt->str : ""; | 
|  |  | 
|  | /* we've gotten past lookup_scalar() */ | 
|  | assert(ov->list_mode == LM_NONE || ov->list_mode == LM_IN_PROGRESS); | 
|  |  | 
|  | errno = 0; | 
|  | val = strtoll(str, &endptr, 0); | 
|  | if (errno == 0 && endptr > str && INT64_MIN <= val && val <= INT64_MAX) { | 
|  | if (*endptr == '\0') { | 
|  | *obj = val; | 
|  | processed(ov, name); | 
|  | return true; | 
|  | } | 
|  | if (*endptr == '-' && ov->list_mode == LM_IN_PROGRESS) { | 
|  | long long val2; | 
|  |  | 
|  | str = endptr + 1; | 
|  | val2 = strtoll(str, &endptr, 0); | 
|  | if (errno == 0 && endptr > str && *endptr == '\0' && | 
|  | INT64_MIN <= val2 && val2 <= INT64_MAX && val <= val2 && | 
|  | (val > INT64_MAX - OPTS_VISITOR_RANGE_MAX || | 
|  | val2 < val + OPTS_VISITOR_RANGE_MAX)) { | 
|  | ov->range_next.s = val; | 
|  | ov->range_limit.s = val2; | 
|  | ov->list_mode = LM_SIGNED_INTERVAL; | 
|  |  | 
|  | /* as if entering on the top */ | 
|  | *obj = ov->range_next.s; | 
|  | return true; | 
|  | } | 
|  | } | 
|  | } | 
|  | error_setg(errp, QERR_INVALID_PARAMETER_VALUE, opt->name, | 
|  | (ov->list_mode == LM_NONE) ? "an int64 value" : | 
|  | "an int64 value or range"); | 
|  | return false; | 
|  | } | 
|  |  | 
|  |  | 
|  | static bool | 
|  | opts_type_uint64(Visitor *v, const char *name, uint64_t *obj, Error **errp) | 
|  | { | 
|  | OptsVisitor *ov = to_ov(v); | 
|  | const QemuOpt *opt; | 
|  | const char *str; | 
|  | uint64_t val; | 
|  | const char *endptr; | 
|  |  | 
|  | if (ov->list_mode == LM_UNSIGNED_INTERVAL) { | 
|  | *obj = ov->range_next.u; | 
|  | return true; | 
|  | } | 
|  |  | 
|  | opt = lookup_scalar(ov, name, errp); | 
|  | if (!opt) { | 
|  | return false; | 
|  | } | 
|  | str = opt->str; | 
|  |  | 
|  | /* we've gotten past lookup_scalar() */ | 
|  | assert(ov->list_mode == LM_NONE || ov->list_mode == LM_IN_PROGRESS); | 
|  |  | 
|  | if (parse_uint(str, &endptr, 0, &val) == 0) { | 
|  | if (*endptr == '\0') { | 
|  | *obj = val; | 
|  | processed(ov, name); | 
|  | return true; | 
|  | } | 
|  | if (*endptr == '-' && ov->list_mode == LM_IN_PROGRESS) { | 
|  | uint64_t val2; | 
|  |  | 
|  | str = endptr + 1; | 
|  | if (parse_uint_full(str, 0, &val2) == 0 && | 
|  | val <= val2 && | 
|  | val2 - val < OPTS_VISITOR_RANGE_MAX) { | 
|  | ov->range_next.u = val; | 
|  | ov->range_limit.u = val2; | 
|  | ov->list_mode = LM_UNSIGNED_INTERVAL; | 
|  |  | 
|  | /* as if entering on the top */ | 
|  | *obj = ov->range_next.u; | 
|  | return true; | 
|  | } | 
|  | } | 
|  | } | 
|  | error_setg(errp, QERR_INVALID_PARAMETER_VALUE, opt->name, | 
|  | (ov->list_mode == LM_NONE) ? "a uint64 value" : | 
|  | "a uint64 value or range"); | 
|  | return false; | 
|  | } | 
|  |  | 
|  |  | 
|  | static bool | 
|  | opts_type_size(Visitor *v, const char *name, uint64_t *obj, Error **errp) | 
|  | { | 
|  | OptsVisitor *ov = to_ov(v); | 
|  | const QemuOpt *opt; | 
|  | int err; | 
|  |  | 
|  | opt = lookup_scalar(ov, name, errp); | 
|  | if (!opt) { | 
|  | return false; | 
|  | } | 
|  |  | 
|  | err = qemu_strtosz(opt->str ? opt->str : "", NULL, obj); | 
|  | if (err < 0) { | 
|  | error_setg(errp, QERR_INVALID_PARAMETER_VALUE, opt->name, | 
|  | "a size value"); | 
|  | return false; | 
|  | } | 
|  |  | 
|  | processed(ov, name); | 
|  | return true; | 
|  | } | 
|  |  | 
|  |  | 
|  | static void | 
|  | opts_optional(Visitor *v, const char *name, bool *present) | 
|  | { | 
|  | OptsVisitor *ov = to_ov(v); | 
|  |  | 
|  | /* we only support a single mandatory scalar field in a list node */ | 
|  | assert(ov->list_mode == LM_NONE); | 
|  | *present = (lookup_distinct(ov, name, NULL) != NULL); | 
|  | } | 
|  |  | 
|  |  | 
|  | static void | 
|  | opts_free(Visitor *v) | 
|  | { | 
|  | OptsVisitor *ov = to_ov(v); | 
|  |  | 
|  | if (ov->unprocessed_opts != NULL) { | 
|  | g_hash_table_destroy(ov->unprocessed_opts); | 
|  | } | 
|  | g_free(ov->fake_id_opt); | 
|  | g_free(ov); | 
|  | } | 
|  |  | 
|  |  | 
|  | Visitor * | 
|  | opts_visitor_new(const QemuOpts *opts) | 
|  | { | 
|  | OptsVisitor *ov; | 
|  |  | 
|  | assert(opts); | 
|  | ov = g_malloc0(sizeof *ov); | 
|  |  | 
|  | ov->visitor.type = VISITOR_INPUT; | 
|  |  | 
|  | ov->visitor.start_struct = &opts_start_struct; | 
|  | ov->visitor.check_struct = &opts_check_struct; | 
|  | ov->visitor.end_struct   = &opts_end_struct; | 
|  |  | 
|  | ov->visitor.start_list = &opts_start_list; | 
|  | ov->visitor.next_list  = &opts_next_list; | 
|  | ov->visitor.check_list = &opts_check_list; | 
|  | ov->visitor.end_list   = &opts_end_list; | 
|  |  | 
|  | ov->visitor.type_int64  = &opts_type_int64; | 
|  | ov->visitor.type_uint64 = &opts_type_uint64; | 
|  | ov->visitor.type_size   = &opts_type_size; | 
|  | ov->visitor.type_bool   = &opts_type_bool; | 
|  | ov->visitor.type_str    = &opts_type_str; | 
|  |  | 
|  | /* type_number() is not filled in, but this is not the first visitor to | 
|  | * skip some mandatory methods... */ | 
|  |  | 
|  | ov->visitor.optional = &opts_optional; | 
|  | ov->visitor.free = opts_free; | 
|  |  | 
|  | ov->opts_root = opts; | 
|  |  | 
|  | return &ov->visitor; | 
|  | } |