X-Git-Url: https://git.notmuchmail.org/git?p=notmuch;a=blobdiff_plain;f=notmuch-restore.c;h=9ed9b515754036ec285f2af214f52fe980d84771;hp=40596a803a5908d1bcf9bce1ea2661c3a98d854d;hb=0919ea4c553bde840a0f37c6076712f345bcac7d;hpb=ea85725450de3e65f1db35112fd621c11dd1cab9 diff --git a/notmuch-restore.c b/notmuch-restore.c index 40596a80..9ed9b515 100644 --- a/notmuch-restore.c +++ b/notmuch-restore.c @@ -25,6 +25,9 @@ static regex_t regex; +/* Non-zero return indicates an error in retrieving the message, + * or in applying the tags. + */ static int tag_message (unused (void *ctx), notmuch_database_t *notmuch, @@ -48,7 +51,7 @@ tag_message (unused (void *ctx), /* In order to detect missing messages, this check/optimization is * intentionally done *after* first finding the message. */ if ((flags & TAG_FLAG_REMOVE_ALL) || tag_op_list_size (tag_ops)) - tag_op_list_apply (message, tag_ops, flags); + ret = tag_op_list_apply (message, tag_ops, flags); notmuch_message_destroy (message); @@ -102,7 +105,7 @@ parse_sup_line (void *ctx, char *line, tok_len++; } - if (tag_op_list_append (ctx, tag_ops, tok, FALSE)) + if (tag_op_list_append (tag_ops, tok, FALSE)) return -1; } @@ -122,6 +125,7 @@ notmuch_restore_command (unused (void *ctx), int argc, char *argv[]) char *input_file_name = NULL; FILE *input = stdin; char *line = NULL; + void *line_ctx = NULL; size_t line_size; ssize_t line_len; @@ -205,10 +209,14 @@ notmuch_restore_command (unused (void *ctx), int argc, char *argv[]) do { char *query_string; + if (line_ctx != NULL) + talloc_free (line_ctx); + + line_ctx = talloc_new (ctx); if (input_format == DUMP_FORMAT_SUP) { - ret = parse_sup_line (ctx, line, &query_string, tag_ops); + ret = parse_sup_line (line_ctx, line, &query_string, tag_ops); } else { - ret = parse_tag_line (ctx, line, TAG_FLAG_BE_GENEROUS, + ret = parse_tag_line (line_ctx, line, TAG_FLAG_BE_GENEROUS, &query_string, tag_ops); if (ret == 0) { @@ -231,12 +239,19 @@ notmuch_restore_command (unused (void *ctx), int argc, char *argv[]) if (ret > 0) continue; - if (ret < 0 || tag_message (ctx, notmuch, query_string, - tag_ops, flags)) + if (ret < 0) + break; + + ret = tag_message (line_ctx, notmuch, query_string, + tag_ops, flags); + if (ret) break; } while ((line_len = getline (&line, &line_size, input)) != -1); + if (line_ctx != NULL) + talloc_free (line_ctx); + if (input_format == DUMP_FORMAT_SUP) regfree (®ex);