]> git.ipfire.org Git - thirdparty/git.git/blobdiff - ref-filter.c
strmap: enable allocations to come from a mem_pool
[thirdparty/git.git] / ref-filter.c
index 8ba0e31915021e3d60b814332c6a10c10f3a147e..5e66b8cd765e0397b7ac41369ec121940671ae1b 100644 (file)
@@ -127,8 +127,8 @@ static struct used_atom {
                        unsigned int nobracket : 1, push : 1, push_remote : 1;
                } remote_ref;
                struct {
-                       enum { C_BARE, C_BODY, C_BODY_DEP, C_LENGTH,
-                              C_LINES, C_SIG, C_SUB, C_TRAILERS } option;
+                       enum { C_BARE, C_BODY, C_BODY_DEP, C_LENGTH, C_LINES,
+                              C_SIG, C_SUB, C_SUB_SANITIZE, C_TRAILERS } option;
                        struct process_trailer_options trailer_opts;
                        unsigned int nlines;
                } contents;
@@ -139,7 +139,10 @@ static struct used_atom {
                struct {
                        enum { O_FULL, O_LENGTH, O_SHORT } option;
                        unsigned int length;
-               } objectname;
+               } oid;
+               struct email_option {
+                       enum { EO_RAW, EO_TRIM, EO_LOCALPART } option;
+               } email_option;
                struct refname_atom refname;
                char *head;
        } u;
@@ -298,9 +301,12 @@ static int body_atom_parser(const struct ref_format *format, struct used_atom *a
 static int subject_atom_parser(const struct ref_format *format, struct used_atom *atom,
                               const char *arg, struct strbuf *err)
 {
-       if (arg)
-               return strbuf_addf_ret(err, -1, _("%%(subject) does not take arguments"));
-       atom->u.contents.option = C_SUB;
+       if (!arg)
+               atom->u.contents.option = C_SUB;
+       else if (!strcmp(arg, "sanitize"))
+               atom->u.contents.option = C_SUB_SANITIZE;
+       else
+               return strbuf_addf_ret(err, -1, _("unrecognized %%(subject) argument: %s"), arg);
        return 0;
 }
 
@@ -360,22 +366,36 @@ static int contents_atom_parser(const struct ref_format *format, struct used_ato
        return 0;
 }
 
-static int objectname_atom_parser(const struct ref_format *format, struct used_atom *atom,
-                                 const char *arg, struct strbuf *err)
+static int oid_atom_parser(const struct ref_format *format, struct used_atom *atom,
+                          const char *arg, struct strbuf *err)
 {
        if (!arg)
-               atom->u.objectname.option = O_FULL;
+               atom->u.oid.option = O_FULL;
        else if (!strcmp(arg, "short"))
-               atom->u.objectname.option = O_SHORT;
+               atom->u.oid.option = O_SHORT;
        else if (skip_prefix(arg, "short=", &arg)) {
-               atom->u.objectname.option = O_LENGTH;
-               if (strtoul_ui(arg, 10, &atom->u.objectname.length) ||
-                   atom->u.objectname.length == 0)
-                       return strbuf_addf_ret(err, -1, _("positive value expected objectname:short=%s"), arg);
-               if (atom->u.objectname.length < MINIMUM_ABBREV)
-                       atom->u.objectname.length = MINIMUM_ABBREV;
+               atom->u.oid.option = O_LENGTH;
+               if (strtoul_ui(arg, 10, &atom->u.oid.length) ||
+                   atom->u.oid.length == 0)
+                       return strbuf_addf_ret(err, -1, _("positive value expected '%s' in %%(%s)"), arg, atom->name);
+               if (atom->u.oid.length < MINIMUM_ABBREV)
+                       atom->u.oid.length = MINIMUM_ABBREV;
        } else
-               return strbuf_addf_ret(err, -1, _("unrecognized %%(objectname) argument: %s"), arg);
+               return strbuf_addf_ret(err, -1, _("unrecognized argument '%s' in %%(%s)"), arg, atom->name);
+       return 0;
+}
+
+static int person_email_atom_parser(const struct ref_format *format, struct used_atom *atom,
+                                   const char *arg, struct strbuf *err)
+{
+       if (!arg)
+               atom->u.email_option.option = EO_RAW;
+       else if (!strcmp(arg, "trim"))
+               atom->u.email_option.option = EO_TRIM;
+       else if (!strcmp(arg, "localpart"))
+               atom->u.email_option.option = EO_LOCALPART;
+       else
+               return strbuf_addf_ret(err, -1, _("unrecognized email option: %s"), arg);
        return 0;
 }
 
@@ -480,25 +500,25 @@ static struct {
        { "refname", SOURCE_NONE, FIELD_STR, refname_atom_parser },
        { "objecttype", SOURCE_OTHER, FIELD_STR, objecttype_atom_parser },
        { "objectsize", SOURCE_OTHER, FIELD_ULONG, objectsize_atom_parser },
-       { "objectname", SOURCE_OTHER, FIELD_STR, objectname_atom_parser },
+       { "objectname", SOURCE_OTHER, FIELD_STR, oid_atom_parser },
        { "deltabase", SOURCE_OTHER, FIELD_STR, deltabase_atom_parser },
-       { "tree", SOURCE_OBJ },
-       { "parent", SOURCE_OBJ },
+       { "tree", SOURCE_OBJ, FIELD_STR, oid_atom_parser },
+       { "parent", SOURCE_OBJ, FIELD_STR, oid_atom_parser },
        { "numparent", SOURCE_OBJ, FIELD_ULONG },
        { "object", SOURCE_OBJ },
        { "type", SOURCE_OBJ },
        { "tag", SOURCE_OBJ },
        { "author", SOURCE_OBJ },
        { "authorname", SOURCE_OBJ },
-       { "authoremail", SOURCE_OBJ },
+       { "authoremail", SOURCE_OBJ, FIELD_STR, person_email_atom_parser },
        { "authordate", SOURCE_OBJ, FIELD_TIME },
        { "committer", SOURCE_OBJ },
        { "committername", SOURCE_OBJ },
-       { "committeremail", SOURCE_OBJ },
+       { "committeremail", SOURCE_OBJ, FIELD_STR, person_email_atom_parser },
        { "committerdate", SOURCE_OBJ, FIELD_TIME },
        { "tagger", SOURCE_OBJ },
        { "taggername", SOURCE_OBJ },
-       { "taggeremail", SOURCE_OBJ },
+       { "taggeremail", SOURCE_OBJ, FIELD_STR, person_email_atom_parser },
        { "taggerdate", SOURCE_OBJ, FIELD_TIME },
        { "creator", SOURCE_OBJ },
        { "creatordate", SOURCE_OBJ, FIELD_TIME },
@@ -903,21 +923,27 @@ int verify_ref_format(struct ref_format *format)
        return 0;
 }
 
-static int grab_objectname(const char *name, const struct object_id *oid,
-                          struct atom_value *v, struct used_atom *atom)
+static const char *do_grab_oid(const char *field, const struct object_id *oid,
+                              struct used_atom *atom)
 {
-       if (starts_with(name, "objectname")) {
-               if (atom->u.objectname.option == O_SHORT) {
-                       v->s = xstrdup(find_unique_abbrev(oid, DEFAULT_ABBREV));
-                       return 1;
-               } else if (atom->u.objectname.option == O_FULL) {
-                       v->s = xstrdup(oid_to_hex(oid));
-                       return 1;
-               } else if (atom->u.objectname.option == O_LENGTH) {
-                       v->s = xstrdup(find_unique_abbrev(oid, atom->u.objectname.length));
-                       return 1;
-               } else
-                       BUG("unknown %%(objectname) option");
+       switch (atom->u.oid.option) {
+       case O_FULL:
+               return oid_to_hex(oid);
+       case O_LENGTH:
+               return find_unique_abbrev(oid, atom->u.oid.length);
+       case O_SHORT:
+               return find_unique_abbrev(oid, DEFAULT_ABBREV);
+       default:
+               BUG("unknown %%(%s) option", field);
+       }
+}
+
+static int grab_oid(const char *name, const char *field, const struct object_id *oid,
+                   struct atom_value *v, struct used_atom *atom)
+{
+       if (starts_with(name, field)) {
+               v->s = xstrdup(do_grab_oid(field, oid, atom));
+               return 1;
        }
        return 0;
 }
@@ -945,7 +971,7 @@ static void grab_common_values(struct atom_value *val, int deref, struct expand_
                } else if (!strcmp(name, "deltabase"))
                        v->s = xstrdup(oid_to_hex(&oi->delta_base_oid));
                else if (deref)
-                       grab_objectname(name, &oi->oid, v, &used_atom[i]);
+                       grab_oid(name, "objectname", &oi->oid, v, &used_atom[i]);
        }
 }
 
@@ -984,21 +1010,20 @@ static void grab_commit_values(struct atom_value *val, int deref, struct object
                        continue;
                if (deref)
                        name++;
-               if (!strcmp(name, "tree")) {
-                       v->s = xstrdup(oid_to_hex(get_commit_tree_oid(commit)));
-               }
-               else if (!strcmp(name, "numparent")) {
+               if (grab_oid(name, "tree", get_commit_tree_oid(commit), v, &used_atom[i]))
+                       continue;
+               if (!strcmp(name, "numparent")) {
                        v->value = commit_list_count(commit->parents);
                        v->s = xstrfmt("%lu", (unsigned long)v->value);
                }
-               else if (!strcmp(name, "parent")) {
+               else if (starts_with(name, "parent")) {
                        struct commit_list *parents;
                        struct strbuf s = STRBUF_INIT;
                        for (parents = commit->parents; parents; parents = parents->next) {
-                               struct commit *parent = parents->item;
+                               struct object_id *oid = &parents->item->object.oid;
                                if (parents != commit->parents)
                                        strbuf_addch(&s, ' ');
-                               strbuf_addstr(&s, oid_to_hex(&parent->object.oid));
+                               strbuf_addstr(&s, do_grab_oid("parent", oid, &used_atom[i]));
                        }
                        v->s = strbuf_detach(&s, NULL);
                }
@@ -1039,16 +1064,35 @@ static const char *copy_name(const char *buf)
        return xstrdup("");
 }
 
-static const char *copy_email(const char *buf)
+static const char *copy_email(const char *buf, struct used_atom *atom)
 {
        const char *email = strchr(buf, '<');
        const char *eoemail;
        if (!email)
                return xstrdup("");
-       eoemail = strchr(email, '>');
+       switch (atom->u.email_option.option) {
+       case EO_RAW:
+               eoemail = strchr(email, '>');
+               if (eoemail)
+                       eoemail++;
+               break;
+       case EO_TRIM:
+               email++;
+               eoemail = strchr(email, '>');
+               break;
+       case EO_LOCALPART:
+               email++;
+               eoemail = strchr(email, '@');
+               if (!eoemail)
+                       eoemail = strchr(email, '>');
+               break;
+       default:
+               BUG("unknown email option");
+       }
+
        if (!eoemail)
                return xstrdup("");
-       return xmemdupz(email, eoemail + 1 - email);
+       return xmemdupz(email, eoemail - email);
 }
 
 static char *copy_subject(const char *buf, unsigned long len)
@@ -1118,7 +1162,7 @@ static void grab_person(const char *who, struct atom_value *val, int deref, void
                        continue;
                if (name[wholen] != 0 &&
                    strcmp(name + wholen, "name") &&
-                   strcmp(name + wholen, "email") &&
+                   !starts_with(name + wholen, "email") &&
                    !starts_with(name + wholen, "date"))
                        continue;
                if (!wholine)
@@ -1129,8 +1173,8 @@ static void grab_person(const char *who, struct atom_value *val, int deref, void
                        v->s = copy_line(wholine);
                else if (!strcmp(name + wholen, "name"))
                        v->s = copy_name(wholine);
-               else if (!strcmp(name + wholen, "email"))
-                       v->s = copy_email(wholine);
+               else if (starts_with(name + wholen, "email"))
+                       v->s = copy_email(wholine, &used_atom[i]);
                else if (starts_with(name + wholen, "date"))
                        grab_date(wholine, v, name);
        }
@@ -1243,8 +1287,8 @@ static void grab_sub_body_contents(struct atom_value *val, int deref, void *buf)
                        continue;
                if (deref)
                        name++;
-               if (strcmp(name, "subject") &&
-                   strcmp(name, "body") &&
+               if (strcmp(name, "body") &&
+                   !starts_with(name, "subject") &&
                    !starts_with(name, "trailers") &&
                    !starts_with(name, "contents"))
                        continue;
@@ -1256,7 +1300,11 @@ static void grab_sub_body_contents(struct atom_value *val, int deref, void *buf)
 
                if (atom->u.contents.option == C_SUB)
                        v->s = copy_subject(subpos, sublen);
-               else if (atom->u.contents.option == C_BODY_DEP)
+               else if (atom->u.contents.option == C_SUB_SANITIZE) {
+                       struct strbuf sb = STRBUF_INIT;
+                       format_sanitized_subject(&sb, subpos, sublen);
+                       v->s = strbuf_detach(&sb, NULL);
+               } else if (atom->u.contents.option == C_BODY_DEP)
                        v->s = xmemdupz(bodypos, bodylen);
                else if (atom->u.contents.option == C_LENGTH)
                        v->s = xstrfmt("%"PRIuMAX, (uintmax_t)strlen(subpos));
@@ -1509,9 +1557,7 @@ char *get_head_description(void)
                strbuf_addstr(&desc, _("no branch"));
        strbuf_addch(&desc, ')');
 
-       free(state.branch);
-       free(state.onto);
-       free(state.detached_from);
+       wt_status_state_free_buffers(&state);
        return strbuf_detach(&desc, NULL);
 }
 
@@ -1706,7 +1752,7 @@ static int populate_value(struct ref_array_item *ref, struct strbuf *err)
                                v->s = xstrdup(buf + 1);
                        }
                        continue;
-               } else if (!deref && grab_objectname(name, &ref->objectname, v, atom)) {
+               } else if (!deref && grab_oid(name, "objectname", &ref->objectname, v, atom)) {
                        continue;
                } else if (!strcmp(name, "HEAD")) {
                        if (atom->u.head && !strcmp(ref->refname, atom->u.head))
@@ -2119,9 +2165,9 @@ static int ref_filter_handler(const char *refname, const struct object_id *oid,
         * obtain the commit using the 'oid' available and discard all
         * non-commits early. The actual filtering is done later.
         */
-       if (filter->merge_commit || filter->with_commit || filter->no_commit || filter->verbose) {
-               commit = lookup_commit_reference_gently(the_repository, oid,
-                                                       1);
+       if (filter->reachable_from || filter->unreachable_from ||
+           filter->with_commit || filter->no_commit || filter->verbose) {
+               commit = lookup_commit_reference_gently(the_repository, oid, 1);
                if (!commit)
                        return 0;
                /* We perform the filtering for the '--contains' option... */
@@ -2176,20 +2222,28 @@ void ref_array_clear(struct ref_array *array)
        used_atom_cnt = 0;
 
        if (ref_to_worktree_map.worktrees) {
-               hashmap_free_entries(&(ref_to_worktree_map.map),
+               hashmap_clear_and_free(&(ref_to_worktree_map.map),
                                        struct ref_to_worktree_entry, ent);
                free_worktrees(ref_to_worktree_map.worktrees);
                ref_to_worktree_map.worktrees = NULL;
        }
 }
 
-static void do_merge_filter(struct ref_filter_cbdata *ref_cbdata)
+#define EXCLUDE_REACHED 0
+#define INCLUDE_REACHED 1
+static void reach_filter(struct ref_array *array,
+                        struct commit_list *check_reachable,
+                        int include_reached)
 {
        struct rev_info revs;
        int i, old_nr;
-       struct ref_filter *filter = ref_cbdata->filter;
-       struct ref_array *array = ref_cbdata->array;
-       struct commit **to_clear = xcalloc(sizeof(struct commit *), array->nr);
+       struct commit **to_clear;
+       struct commit_list *cr;
+
+       if (!check_reachable)
+               return;
+
+       to_clear = xcalloc(sizeof(struct commit *), array->nr);
 
        repo_init_revisions(the_repository, &revs, NULL);
 
@@ -2199,8 +2253,11 @@ static void do_merge_filter(struct ref_filter_cbdata *ref_cbdata)
                to_clear[i] = item->commit;
        }
 
-       filter->merge_commit->object.flags |= UNINTERESTING;
-       add_pending_object(&revs, &filter->merge_commit->object, "");
+       for (cr = check_reachable; cr; cr = cr->next) {
+               struct commit *merge_commit = cr->item;
+               merge_commit->object.flags |= UNINTERESTING;
+               add_pending_object(&revs, &merge_commit->object, "");
+       }
 
        revs.limited = 1;
        if (prepare_revision_walk(&revs))
@@ -2215,14 +2272,19 @@ static void do_merge_filter(struct ref_filter_cbdata *ref_cbdata)
 
                int is_merged = !!(commit->object.flags & UNINTERESTING);
 
-               if (is_merged == (filter->merge == REF_FILTER_MERGED_INCLUDE))
+               if (is_merged == include_reached)
                        array->items[array->nr++] = array->items[i];
                else
                        free_array_item(item);
        }
 
        clear_commit_marks_many(old_nr, to_clear, ALL_REV_FLAGS);
-       clear_commit_marks(filter->merge_commit, ALL_REV_FLAGS);
+
+       while (check_reachable) {
+               struct commit *merge_commit = pop_commit(&check_reachable);
+               clear_commit_marks(merge_commit, ALL_REV_FLAGS);
+       }
+
        free(to_clear);
 }
 
@@ -2274,8 +2336,8 @@ int filter_refs(struct ref_array *array, struct ref_filter *filter, unsigned int
        clear_contains_cache(&ref_cbdata.no_contains_cache);
 
        /*  Filters that need revision walking */
-       if (filter->merge_commit)
-               do_merge_filter(&ref_cbdata);
+       reach_filter(array, filter->reachable_from, INCLUDE_REACHED);
+       reach_filter(array, filter->unreachable_from, EXCLUDE_REACHED);
 
        return ret;
 }
@@ -2493,31 +2555,22 @@ int parse_opt_merge_filter(const struct option *opt, const char *arg, int unset)
 {
        struct ref_filter *rf = opt->value;
        struct object_id oid;
-       int no_merged = starts_with(opt->long_name, "no");
+       struct commit *merge_commit;
 
        BUG_ON_OPT_NEG(unset);
 
-       if (rf->merge) {
-               if (no_merged) {
-                       return error(_("option `%s' is incompatible with --merged"),
-                                    opt->long_name);
-               } else {
-                       return error(_("option `%s' is incompatible with --no-merged"),
-                                    opt->long_name);
-               }
-       }
-
-       rf->merge = no_merged
-               ? REF_FILTER_MERGED_OMIT
-               : REF_FILTER_MERGED_INCLUDE;
-
        if (get_oid(arg, &oid))
                die(_("malformed object name %s"), arg);
 
-       rf->merge_commit = lookup_commit_reference_gently(the_repository,
-                                                         &oid, 0);
-       if (!rf->merge_commit)
+       merge_commit = lookup_commit_reference_gently(the_repository, &oid, 0);
+
+       if (!merge_commit)
                return error(_("option `%s' must point to a commit"), opt->long_name);
 
+       if (starts_with(opt->long_name, "no"))
+               commit_list_insert(merge_commit, &rf->unreachable_from);
+       else
+               commit_list_insert(merge_commit, &rf->reachable_from);
+
        return 0;
 }