X-Git-Url: https://git.ozlabs.org/?p=petitboot;a=blobdiff_plain;f=discover%2Fparser.c;h=641e06b1cb54e9bdf34d1547e8a3de465a2097f2;hp=8f2735ccc6553b3d00bdc575b5debdd7b7203a3a;hb=45e92aa32a80fdbbf5ad3ad64e34b1ac872018ef;hpb=4b77f0c4b55ff443ea06854cd12098ffce233c8a diff --git a/discover/parser.c b/discover/parser.c index 8f2735c..641e06b 100644 --- a/discover/parser.c +++ b/discover/parser.c @@ -1,46 +1,124 @@ +#include #include +#include +#include -#include "pb-protocol/pb-protocol.h" +#include "types/types.h" #include +#include #include "device-handler.h" #include "parser.h" #include "parser-utils.h" +#include "paths.h" -extern struct parser __start_parsers[], __stop_parsers[]; +static int n_parsers; +static struct parser **parsers; -void iterate_parsers(struct discover_context *ctx) +static const int max_file_size = 1024 * 1024; + +static int read_file(struct discover_context *ctx, + const char *filename, char **bufp, int *lenp) { - struct parser *parser; - unsigned int count = 0; + struct stat statbuf; + int rc, fd, i, len; + char *buf; + + fd = open(filename, O_RDONLY); + if (fd < 0) + return -1; + + rc = fstat(fd, &statbuf); + if (rc < 0) + goto err_close; + + len = statbuf.st_size; + if (len > max_file_size) + goto err_close; + + buf = talloc_array(ctx, char, len); + if (!buf) + goto err_close; + + for (i = 0; i < len; i += rc) { + rc = read(fd, buf + i, len - i); - pb_log("trying parsers for %s\n", ctx->device_path); + /* unexpected EOF: trim and return */ + if (rc == 0) { + len = i; + break; + } + + if (rc < 0) + goto err_free; - for (parser = __start_parsers; parser < __stop_parsers; parser++) { - pb_log("\ttrying parser '%s'\n", parser->name); - count += parser->parse(ctx); } - if (!count) - pb_log("\tno boot_options found\n"); + + close(fd); + *bufp = buf; + *lenp = len; + return 0; + +err_free: + talloc_free(buf); +err_close: + close(fd); + return -1; } -static int compare_parsers(const void *a, const void *b) +static char *local_path(struct discover_context *ctx, + const char *filename) { - const struct parser *parser_a = a, *parser_b = b; + return join_paths(ctx, ctx->device->mount_path, filename); +} - if (parser_a->priority > parser_b->priority) - return -1; +static void iterate_parser_files(struct discover_context *ctx, + const struct parser *parser) +{ + const char * const *filename; + const char *path; - if (parser_a->priority < parser_b->priority) - return 1; + if (!parser->filenames) + return; - return 0; + for (filename = parser->filenames; *filename; filename++) { + int rc, len; + char *buf; + + path = local_path(ctx, *filename); + if (!path) + continue; + + rc = read_file(ctx, path, &buf, &len); + if (!rc) { + parser->parse(ctx, buf, len); + talloc_free(buf); + } + } +} + +void iterate_parsers(struct discover_context *ctx) +{ + int i; + + pb_log("trying parsers for %s\n", ctx->device->device->id); + + for (i = 0; i < n_parsers; i++) { + pb_log("\ttrying parser '%s'\n", parsers[i]->name); + ctx->parser = parsers[i]; + iterate_parser_files(ctx, parsers[i]); + } + ctx->parser = NULL; +} + +void __register_parser(struct parser *parser) +{ + parsers = talloc_realloc(NULL, parsers, struct parser *, n_parsers + 1); + parsers[n_parsers] = parser; + n_parsers++; } void parser_init(void) { - /* sort our parsers into descending priority order */ - qsort(__start_parsers, __stop_parsers - __start_parsers, - sizeof(struct parser), compare_parsers); }