X-Git-Url: http://git.archive.openwrt.org/?p=project%2Fuci.git;a=blobdiff_plain;f=file.c;h=8d4408d43e4b78bd6c3af86d98e5ef5df4c8f231;hp=a58ac559e55aedda25730ea2a0d4a86f978d5e53;hb=471dcf63d6ed4689cfd56f2648e6d1b48f46f14c;hpb=4fb6a564b8eebe01f46766b8238a64d6414ed3ba diff --git a/file.c b/file.c index a58ac55..8d4408d 100644 --- a/file.c +++ b/file.c @@ -9,7 +9,7 @@ * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU General Public License for more details. + * GNU Lesser General Public License for more details. */ /* @@ -18,6 +18,7 @@ #define _GNU_SOURCE #include +#include #include #include #include @@ -25,24 +26,323 @@ #include #include #include +#include +#include + +#include "uci.h" +#include "uci_internal.h" + +#define LINEBUF 32 +#define LINEBUF_MAX 4096 + +/* + * Fetch a new line from the input stream and resize buffer if necessary + */ +__private void uci_getln(struct uci_context *ctx, int offset) +{ + struct uci_parse_context *pctx = ctx->pctx; + char *p; + int ofs; + + if (pctx->buf == NULL) { + pctx->buf = uci_malloc(ctx, LINEBUF); + pctx->bufsz = LINEBUF; + } + /* `offset' may off by one */ + if (offset >= pctx->bufsz) { + pctx->bufsz *= 2; + pctx->buf = uci_realloc(ctx, pctx->buf, pctx->bufsz); + } + + ofs = offset; + do { + p = &pctx->buf[ofs]; + p[0] = 0; + + p = fgets(p, pctx->bufsz - ofs, pctx->file); + if (!p || !*p) + return; + + ofs += strlen(p); + if (pctx->buf[ofs - 1] == '\n') { + pctx->line++; + return; + } + + if (pctx->bufsz > LINEBUF_MAX/2) + uci_parse_error(ctx, "line too long"); + + pctx->bufsz *= 2; + pctx->buf = uci_realloc(ctx, pctx->buf, pctx->bufsz); + } while (1); +} + +/* + * parse a character escaped by '\' + * returns true if the escaped character is to be parsed + * returns false if the escaped character is to be ignored + */ +static bool parse_backslash(struct uci_context *ctx) +{ + struct uci_parse_context *pctx = ctx->pctx; + + /* skip backslash */ + pctx->pos += 1; + + /* undecoded backslash at the end of line, fetch the next line */ + if (!pctx_cur_char(pctx) + || pctx_cur_char(pctx) == '\n' + || (pctx_cur_char(pctx) == '\r' && + pctx_char(pctx, pctx_pos(pctx) + 1) == '\n' && + !pctx_char(pctx, pctx_pos(pctx) + 2))) { + uci_getln(ctx, pctx->pos); + return false; + } + + /* FIXME: decode escaped char, necessary? */ + return true; +} + +/* + * move the string pointer forward until a non-whitespace character or + * EOL is reached + */ +static void skip_whitespace(struct uci_context *ctx) +{ + struct uci_parse_context *pctx = ctx->pctx; + + while (pctx_cur_char(pctx) && isspace(pctx_cur_char(pctx))) + pctx->pos += 1; +} + +static inline void addc(struct uci_context *ctx, int *pos_dest, int *pos_src) +{ + struct uci_parse_context *pctx = ctx->pctx; + + pctx_char(pctx, *pos_dest) = pctx_char(pctx, *pos_src); + *pos_dest += 1; + *pos_src += 1; +} + +/* + * parse a double quoted string argument from the command line + */ +static void parse_double_quote(struct uci_context *ctx, int *target) +{ + struct uci_parse_context *pctx = ctx->pctx; + char c; + + /* skip quote character */ + pctx->pos += 1; + + while (1) { + c = pctx_cur_char(pctx); + switch(c) { + case '"': + pctx->pos += 1; + return; + case 0: + /* Multi-line str value */ + uci_getln(ctx, pctx->pos); + if (!pctx_cur_char(pctx)) { + uci_parse_error(ctx, "EOF with unterminated \""); + } + break; + case '\\': + if (!parse_backslash(ctx)) + continue; + /* fall through */ + default: + addc(ctx, target, &pctx->pos); + break; + } + } + uci_parse_error(ctx, "unterminated \""); +} + +/* + * parse a single quoted string argument from the command line + */ +static void parse_single_quote(struct uci_context *ctx, int *target) +{ + struct uci_parse_context *pctx = ctx->pctx; + char c; + /* skip quote character */ + pctx->pos += 1; + + while (1) { + c = pctx_cur_char(pctx); + switch(c) { + case '\'': + pctx->pos += 1; + return; + case 0: + /* Multi-line str value */ + uci_getln(ctx, pctx->pos); + if (!pctx_cur_char(pctx)) { + uci_parse_error(ctx, "EOF with unterminated \""); + } + break; + default: + addc(ctx, target, &pctx->pos); + } + } + uci_parse_error(ctx, "unterminated '"); +} + +/* + * parse a string from the command line and detect the quoting style + */ +static void parse_str(struct uci_context *ctx, int *target) +{ + struct uci_parse_context *pctx = ctx->pctx; + bool next = true; + do { + switch(pctx_cur_char(pctx)) { + case '\'': + parse_single_quote(ctx, target); + break; + case '"': + parse_double_quote(ctx, target); + break; + case '#': + pctx_cur_char(pctx) = 0; + /* fall through */ + case 0: + goto done; + case ';': + next = false; + goto done; + case '\\': + if (!parse_backslash(ctx)) + continue; + /* fall through */ + default: + addc(ctx, target, &pctx->pos); + break; + } + } while (pctx_cur_char(pctx) && !isspace(pctx_cur_char(pctx))); +done: + + /* + * if the string was unquoted and we've stopped at a whitespace + * character, skip to the next one, because the whitespace will + * be overwritten by a null byte here + */ + if (pctx_cur_char(pctx) && next) + pctx->pos += 1; + + /* terminate the parsed string */ + pctx_char(pctx, *target) = 0; +} + +/* + * extract the next argument from the command line + */ +static char *next_arg(struct uci_context *ctx, bool required, bool name) +{ + struct uci_parse_context *pctx = ctx->pctx; + int val, ptr; + + skip_whitespace(ctx); + val = ptr = pctx_pos(pctx); + if(pctx_cur_char(pctx) == ';') { + pctx_cur_char(pctx) = 0; + pctx->pos += 1; + } else { + parse_str(ctx, &ptr); + } + if (!pctx_char(pctx, val)) { + if (required) + uci_parse_error(ctx, "insufficient arguments"); + goto done; + } + + if (name && !uci_validate_name(pctx_str(pctx, val))) + uci_parse_error(ctx, "invalid character in name field"); + +done: + return pctx_str(pctx, val); +} + +int uci_parse_argument(struct uci_context *ctx, FILE *stream, char **str, char **result) +{ + UCI_HANDLE_ERR(ctx); + UCI_ASSERT(ctx, str != NULL); + UCI_ASSERT(ctx, result != NULL); + + if (ctx->pctx && (ctx->pctx->file != stream)) + uci_cleanup(ctx); + + if (!ctx->pctx) + uci_alloc_parse_context(ctx); + + ctx->pctx->file = stream; + + if (!*str) { + uci_getln(ctx, 0); + *str = ctx->pctx->buf; + } else { + UCI_ASSERT(ctx, ctx->pctx->pos == *str - ctx->pctx->buf); + } + + *result = next_arg(ctx, false, false); + + return 0; +} + +static int +uci_fill_ptr(struct uci_context *ctx, struct uci_ptr *ptr, struct uci_element *e) +{ + UCI_ASSERT(ctx, ptr != NULL); + UCI_ASSERT(ctx, e != NULL); + + memset(ptr, 0, sizeof(struct uci_ptr)); + switch(e->type) { + case UCI_TYPE_OPTION: + ptr->o = uci_to_option(e); + goto fill_option; + case UCI_TYPE_SECTION: + ptr->s = uci_to_section(e); + goto fill_section; + case UCI_TYPE_PACKAGE: + ptr->p = uci_to_package(e); + goto fill_package; + default: + UCI_THROW(ctx, UCI_ERR_INVAL); + } + +fill_option: + ptr->option = ptr->o->e.name; + ptr->s = ptr->o->section; +fill_section: + ptr->section = ptr->s->e.name; + ptr->p = ptr->s->package; +fill_package: + ptr->package = ptr->p->e.name; + + ptr->flags |= UCI_LOOKUP_DONE; + + return 0; +} + -static struct uci_backend uci_file_backend; /* * verify that the end of the line or command is reached. * throw an error if extra arguments are given on the command line */ -static void assert_eol(struct uci_context *ctx, char **str) +static void assert_eol(struct uci_context *ctx) { char *tmp; - skip_whitespace(ctx, str); - tmp = next_arg(ctx, str, false, false); + skip_whitespace(ctx); + tmp = next_arg(ctx, false, false); if (*tmp && (ctx->flags & UCI_FLAG_STRICT)) - uci_parse_error(ctx, *str, "too many arguments"); + uci_parse_error(ctx, "too many arguments"); } -/* +/* * switch to a different config, either triggered by uci_load, or by a * 'package <...>' statement in the import file */ @@ -67,7 +367,7 @@ static void uci_switch_config(struct uci_context *ctx) if (!name) return; - /* + /* * if an older config under the same name exists, unload it * ignore errors here, e.g. if the config was not found */ @@ -80,15 +380,16 @@ static void uci_switch_config(struct uci_context *ctx) /* * parse the 'package' uci command (next config package) */ -static void uci_parse_package(struct uci_context *ctx, char **str, bool single) +static void uci_parse_package(struct uci_context *ctx, bool single) { + struct uci_parse_context *pctx = ctx->pctx; char *name = NULL; /* command string null-terminated by strtok */ - *str += strlen(*str) + 1; + pctx->pos += strlen(pctx_cur_str(pctx)) + 1; - name = next_arg(ctx, str, true, true); - assert_eol(ctx, str); + name = next_arg(ctx, true, true); + assert_eol(ctx); if (single) return; @@ -99,7 +400,7 @@ static void uci_parse_package(struct uci_context *ctx, char **str, bool single) /* * parse the 'config' uci command (open a section) */ -static void uci_parse_config(struct uci_context *ctx, char **str) +static void uci_parse_config(struct uci_context *ctx) { struct uci_parse_context *pctx = ctx->pctx; struct uci_element *e; @@ -110,25 +411,25 @@ static void uci_parse_config(struct uci_context *ctx, char **str) uci_fixup_section(ctx, ctx->pctx->section); if (!ctx->pctx->package) { if (!ctx->pctx->name) - uci_parse_error(ctx, *str, "attempting to import a file without a package name"); + uci_parse_error(ctx, "attempting to import a file without a package name"); uci_switch_config(ctx); } /* command string null-terminated by strtok */ - *str += strlen(*str) + 1; + pctx->pos += strlen(pctx_cur_str(pctx)) + 1; - type = next_arg(ctx, str, true, false); - if (!uci_validate_str(type, false)) - uci_parse_error(ctx, type, "invalid character in field"); - name = next_arg(ctx, str, false, true); - assert_eol(ctx, str); + type = next_arg(ctx, true, false); + if (!uci_validate_type(type)) + uci_parse_error(ctx, "invalid character in type field"); + name = next_arg(ctx, false, true); + assert_eol(ctx); - if (!name) { + if (!name || !name[0]) { ctx->internal = !pctx->merge; UCI_NESTED(uci_add_section, ctx, pctx->package, type, &pctx->section); } else { - UCI_NESTED(uci_fill_ptr, ctx, &ptr, &pctx->package->e, false); + uci_fill_ptr(ctx, &ptr, &pctx->package->e); e = uci_lookup_list(&pctx->package->sections, name); if (e) ptr.s = uci_to_section(e); @@ -144,7 +445,7 @@ static void uci_parse_config(struct uci_context *ctx, char **str) /* * parse the 'option' uci command (open a value) */ -static void uci_parse_option(struct uci_context *ctx, char **str, bool list) +static void uci_parse_option(struct uci_context *ctx, bool list) { struct uci_parse_context *pctx = ctx->pctx; struct uci_element *e; @@ -153,16 +454,16 @@ static void uci_parse_option(struct uci_context *ctx, char **str, bool list) char *value = NULL; if (!pctx->section) - uci_parse_error(ctx, *str, "option/list command found before the first section"); + uci_parse_error(ctx, "option/list command found before the first section"); /* command string null-terminated by strtok */ - *str += strlen(*str) + 1; + pctx->pos += strlen(pctx_cur_str(pctx)) + 1; - name = next_arg(ctx, str, true, true); - value = next_arg(ctx, str, false, false); - assert_eol(ctx, str); + name = next_arg(ctx, true, true); + value = next_arg(ctx, false, false); + assert_eol(ctx); - UCI_NESTED(uci_fill_ptr, ctx, &ptr, &pctx->section->e, false); + uci_fill_ptr(ctx, &ptr, &pctx->section->e); e = uci_lookup_list(&pctx->section->options, name); if (e) ptr.o = uci_to_option(e); @@ -182,12 +483,12 @@ static void uci_parse_option(struct uci_context *ctx, char **str, bool list) static void uci_parse_line(struct uci_context *ctx, bool single) { struct uci_parse_context *pctx = ctx->pctx; - char *word, *brk; + char *word; - word = pctx->buf; + /* Skip whitespace characters at the start of line */ + skip_whitespace(ctx); do { - brk = NULL; - word = strtok_r(word, " \t", &brk); + word = strtok(pctx_cur_str(pctx), " \t"); if (!word) return; @@ -197,25 +498,25 @@ static void uci_parse_line(struct uci_context *ctx, bool single) return; case 'p': if ((word[1] == 0) || !strcmp(word + 1, "ackage")) - uci_parse_package(ctx, &word, single); + uci_parse_package(ctx, single); else goto invalid; break; case 'c': if ((word[1] == 0) || !strcmp(word + 1, "onfig")) - uci_parse_config(ctx, &word); + uci_parse_config(ctx); else goto invalid; break; case 'o': if ((word[1] == 0) || !strcmp(word + 1, "ption")) - uci_parse_option(ctx, &word, false); + uci_parse_option(ctx, false); else goto invalid; break; case 'l': if ((word[1] == 0) || !strcmp(word + 1, "ist")) - uci_parse_option(ctx, &word, true); + uci_parse_option(ctx, true); else goto invalid; break; @@ -224,7 +525,7 @@ static void uci_parse_line(struct uci_context *ctx, bool single) } continue; invalid: - uci_parse_error(ctx, word, "invalid command"); + uci_parse_error(ctx, "invalid command"); } while (1); } @@ -234,7 +535,7 @@ invalid: /* * escape an uci string for export */ -static char *uci_escape(struct uci_context *ctx, const char *str) +static const char *uci_escape(struct uci_context *ctx, const char *str) { const char *end; int ofs = 0; @@ -242,6 +543,9 @@ static char *uci_escape(struct uci_context *ctx, const char *str) if (!ctx->buf) { ctx->bufsz = LINEBUF; ctx->buf = malloc(LINEBUF); + + if (!ctx->buf) + return str; } while (1) { @@ -284,10 +588,10 @@ static void uci_export_package(struct uci_package *p, FILE *stream, bool header) struct uci_element *s, *o, *i; if (header) - fprintf(stream, "package '%s'\n", uci_escape(ctx, p->e.name)); + fprintf(stream, "package %s\n", uci_escape(ctx, p->e.name)); uci_foreach_element(&p->sections, s) { struct uci_section *sec = uci_to_section(s); - fprintf(stream, "\nconfig '%s'", uci_escape(ctx, sec->type)); + fprintf(stream, "\nconfig %s", uci_escape(ctx, sec->type)); if (!sec->anonymous || (ctx->flags & UCI_FLAG_EXPORT_NAME)) fprintf(stream, " '%s'", uci_escape(ctx, sec->e.name)); fprintf(stream, "\n"); @@ -295,12 +599,12 @@ static void uci_export_package(struct uci_package *p, FILE *stream, bool header) struct uci_option *opt = uci_to_option(o); switch(opt->type) { case UCI_TYPE_STRING: - fprintf(stream, "\toption '%s'", uci_escape(ctx, opt->e.name)); + fprintf(stream, "\toption %s", uci_escape(ctx, opt->e.name)); fprintf(stream, " '%s'\n", uci_escape(ctx, opt->v.string)); break; case UCI_TYPE_LIST: uci_foreach_element(&opt->v.list, i) { - fprintf(stream, "\tlist '%s'", uci_escape(ctx, opt->e.name)); + fprintf(stream, "\tlist %s", uci_escape(ctx, opt->e.name)); fprintf(stream, " '%s'\n", uci_escape(ctx, i->name)); } break; @@ -342,7 +646,7 @@ int uci_import(struct uci_context *ctx, FILE *stream, const char *name, struct u uci_alloc_parse_context(ctx); pctx = ctx->pctx; pctx->file = stream; - if (*package && single) { + if (package && *package && single) { pctx->package = *package; pctx->merge = true; } @@ -353,11 +657,12 @@ int uci_import(struct uci_context *ctx, FILE *stream, const char *name, struct u * NB: the config file can still override the package name */ if (name) { - UCI_ASSERT(ctx, uci_validate_str(name, false)); + UCI_ASSERT(ctx, uci_validate_package(name)); pctx->name = name; } while (!feof(pctx->file)) { + pctx->pos = 0; uci_getln(ctx, 0); UCI_TRAP_SAVE(ctx, error); if (pctx->buf[0]) @@ -394,19 +699,22 @@ static char *uci_config_path(struct uci_context *ctx, const char *name) { char *filename; - UCI_ASSERT(ctx, uci_validate_str(name, false)); + UCI_ASSERT(ctx, uci_validate_package(name)); filename = uci_malloc(ctx, strlen(name) + strlen(ctx->confdir) + 2); sprintf(filename, "%s/%s", ctx->confdir, name); return filename; } -void uci_file_commit(struct uci_context *ctx, struct uci_package **package, bool overwrite) +static void uci_file_commit(struct uci_context *ctx, struct uci_package **package, bool overwrite) { struct uci_package *p = *package; - FILE *f = NULL; + FILE *f1, *f2 = NULL; char *name = NULL; char *path = NULL; + char *filename = NULL; + struct stat statbuf; + bool do_rename = false; if (!p->path) { if (overwrite) @@ -415,62 +723,81 @@ void uci_file_commit(struct uci_context *ctx, struct uci_package **package, bool UCI_THROW(ctx, UCI_ERR_INVAL); } + if ((asprintf(&filename, "%s/.%s.uci-XXXXXX", ctx->confdir, p->e.name) < 0) || !filename) + UCI_THROW(ctx, UCI_ERR_MEM); + + if (!mktemp(filename)) + *filename = 0; + + if (!*filename) { + free(filename); + UCI_THROW(ctx, UCI_ERR_IO); + } + + if ((stat(filename, &statbuf) == 0) && ((statbuf.st_mode & S_IFMT) != S_IFREG)) + UCI_THROW(ctx, UCI_ERR_IO); + /* open the config file for writing now, so that it is locked */ - f = uci_open_stream(ctx, p->path, SEEK_SET, true, true); + f1 = uci_open_stream(ctx, p->path, NULL, SEEK_SET, true, true); - /* flush unsaved changes and reload from history file */ + /* flush unsaved changes and reload from delta file */ UCI_TRAP_SAVE(ctx, done); - if (p->has_history) { + if (p->has_delta) { if (!overwrite) { name = uci_strdup(ctx, p->e.name); path = uci_strdup(ctx, p->path); - /* dump our own changes to the history file */ - if (!uci_list_empty(&p->history)) + /* dump our own changes to the delta file */ + if (!uci_list_empty(&p->delta)) UCI_INTERNAL(uci_save, ctx, p); - /* - * other processes might have modified the config - * as well. dump and reload + /* + * other processes might have modified the config + * as well. dump and reload */ uci_free_package(&p); uci_cleanup(ctx); - UCI_INTERNAL(uci_import, ctx, f, name, &p, true); + UCI_INTERNAL(uci_import, ctx, f1, name, &p, true); p->path = path; - p->has_history = true; + p->has_delta = true; *package = p; /* freed together with the uci_package */ path = NULL; - - /* check for updated history, flush */ - if (!uci_load_history(ctx, p, true)) - goto done; - } else { - /* flush history */ - if (!uci_load_history(ctx, NULL, true)) - goto done; } + + /* flush delta */ + if (!uci_load_delta(ctx, p, true)) + goto done; } - rewind(f); - ftruncate(fileno(f), 0); + f2 = uci_open_stream(ctx, filename, p->path, SEEK_SET, true, true); + uci_export(ctx, f2, p, false); + + fflush(f2); + fsync(fileno(f2)); + uci_close_stream(f2); + + do_rename = true; - uci_export(ctx, f, p, false); UCI_TRAP_RESTORE(ctx); done: - if (name) - free(name); - if (path) - free(path); - uci_close_stream(f); + free(name); + free(path); + uci_close_stream(f1); + if (do_rename && rename(filename, p->path)) { + unlink(filename); + UCI_THROW(ctx, UCI_ERR_IO); + } + free(filename); + sync(); if (ctx->err) UCI_THROW(ctx, ctx->err); } -/* +/* * This function returns the filename by returning the string * after the last '/' character. By checking for a non-'\0' * character afterwards, directories are ignored (glob marks @@ -497,8 +824,10 @@ static char **uci_list_config_files(struct uci_context *ctx) dir = uci_malloc(ctx, strlen(ctx->confdir) + 1 + sizeof("/*")); sprintf(dir, "%s/*", ctx->confdir); - if (glob(dir, GLOB_MARK, NULL, &globbuf) != 0) + if (glob(dir, GLOB_MARK, NULL, &globbuf) != 0) { + free(dir); UCI_THROW(ctx, UCI_ERR_NOTFOUND); + } size = sizeof(char *) * (globbuf.gl_pathc + 1); for(i = 0; i < globbuf.gl_pathc; i++) { @@ -520,7 +849,7 @@ static char **uci_list_config_files(struct uci_context *ctx) if (!p) continue; - if (!uci_validate_name(p)) + if (!uci_validate_package(p)) continue; configs[i] = buf; @@ -528,6 +857,7 @@ static char **uci_list_config_files(struct uci_context *ctx) buf += strlen(buf) + 1; } free(dir); + globfree(&globbuf); return configs; } @@ -557,26 +887,28 @@ static struct uci_package *uci_file_load(struct uci_context *ctx, const char *na break; } - file = uci_open_stream(ctx, filename, SEEK_SET, false, false); - ctx->err = 0; UCI_TRAP_SAVE(ctx, done); + file = uci_open_stream(ctx, filename, NULL, SEEK_SET, false, false); + ctx->err = 0; UCI_INTERNAL(uci_import, ctx, file, name, &package, true); UCI_TRAP_RESTORE(ctx); if (package) { package->path = filename; - package->has_history = confdir; - uci_load_history(ctx, package, false); + package->has_delta = confdir; + uci_load_delta(ctx, package, false); } done: uci_close_stream(file); - if (ctx->err) + if (ctx->err) { + free(filename); UCI_THROW(ctx, ctx->err); + } return package; } -static UCI_BACKEND(uci_file_backend, "file", +__private UCI_BACKEND(uci_file_backend, "file", .load = uci_file_load, .commit = uci_file_commit, .list_configs = uci_list_config_files,