ba5b3d378f1bd2d52b6685d3050b724dd5c9890c
   1#include "builtin.h"
   2#include "lockfile.h"
   3#include "commit.h"
   4#include "refs.h"
   5#include "dir.h"
   6#include "tree-walk.h"
   7#include "diff.h"
   8#include "revision.h"
   9#include "reachable.h"
  10
  11/*
  12 * reflog expire
  13 */
  14
  15static const char reflog_expire_usage[] =
  16"git reflog expire [--verbose] [--dry-run] [--stale-fix] [--expire=<time>] [--expire-unreachable=<time>] [--all] <refs>...";
  17static const char reflog_delete_usage[] =
  18"git reflog delete [--verbose] [--dry-run] [--rewrite] [--updateref] <refs>...";
  19
  20static unsigned long default_reflog_expire;
  21static unsigned long default_reflog_expire_unreachable;
  22
  23struct cmd_reflog_expire_cb {
  24        struct rev_info revs;
  25        int dry_run;
  26        int stalefix;
  27        int rewrite;
  28        int updateref;
  29        int verbose;
  30        unsigned long expire_total;
  31        unsigned long expire_unreachable;
  32        int recno;
  33};
  34
  35struct expire_reflog_cb {
  36        FILE *newlog;
  37        enum {
  38                UE_NORMAL,
  39                UE_ALWAYS,
  40                UE_HEAD
  41        } unreachable_expire_kind;
  42        struct commit_list *mark_list;
  43        unsigned long mark_limit;
  44        struct cmd_reflog_expire_cb *cmd;
  45        unsigned char last_kept_sha1[20];
  46};
  47
  48struct collected_reflog {
  49        unsigned char sha1[20];
  50        char reflog[FLEX_ARRAY];
  51};
  52struct collect_reflog_cb {
  53        struct collected_reflog **e;
  54        int alloc;
  55        int nr;
  56};
  57
  58#define INCOMPLETE      (1u<<10)
  59#define STUDYING        (1u<<11)
  60#define REACHABLE       (1u<<12)
  61
  62static int tree_is_complete(const unsigned char *sha1)
  63{
  64        struct tree_desc desc;
  65        struct name_entry entry;
  66        int complete;
  67        struct tree *tree;
  68
  69        tree = lookup_tree(sha1);
  70        if (!tree)
  71                return 0;
  72        if (tree->object.flags & SEEN)
  73                return 1;
  74        if (tree->object.flags & INCOMPLETE)
  75                return 0;
  76
  77        if (!tree->buffer) {
  78                enum object_type type;
  79                unsigned long size;
  80                void *data = read_sha1_file(sha1, &type, &size);
  81                if (!data) {
  82                        tree->object.flags |= INCOMPLETE;
  83                        return 0;
  84                }
  85                tree->buffer = data;
  86                tree->size = size;
  87        }
  88        init_tree_desc(&desc, tree->buffer, tree->size);
  89        complete = 1;
  90        while (tree_entry(&desc, &entry)) {
  91                if (!has_sha1_file(entry.sha1) ||
  92                    (S_ISDIR(entry.mode) && !tree_is_complete(entry.sha1))) {
  93                        tree->object.flags |= INCOMPLETE;
  94                        complete = 0;
  95                }
  96        }
  97        free_tree_buffer(tree);
  98
  99        if (complete)
 100                tree->object.flags |= SEEN;
 101        return complete;
 102}
 103
 104static int commit_is_complete(struct commit *commit)
 105{
 106        struct object_array study;
 107        struct object_array found;
 108        int is_incomplete = 0;
 109        int i;
 110
 111        /* early return */
 112        if (commit->object.flags & SEEN)
 113                return 1;
 114        if (commit->object.flags & INCOMPLETE)
 115                return 0;
 116        /*
 117         * Find all commits that are reachable and are not marked as
 118         * SEEN.  Then make sure the trees and blobs contained are
 119         * complete.  After that, mark these commits also as SEEN.
 120         * If some of the objects that are needed to complete this
 121         * commit are missing, mark this commit as INCOMPLETE.
 122         */
 123        memset(&study, 0, sizeof(study));
 124        memset(&found, 0, sizeof(found));
 125        add_object_array(&commit->object, NULL, &study);
 126        add_object_array(&commit->object, NULL, &found);
 127        commit->object.flags |= STUDYING;
 128        while (study.nr) {
 129                struct commit *c;
 130                struct commit_list *parent;
 131
 132                c = (struct commit *)study.objects[--study.nr].item;
 133                if (!c->object.parsed && !parse_object(c->object.sha1))
 134                        c->object.flags |= INCOMPLETE;
 135
 136                if (c->object.flags & INCOMPLETE) {
 137                        is_incomplete = 1;
 138                        break;
 139                }
 140                else if (c->object.flags & SEEN)
 141                        continue;
 142                for (parent = c->parents; parent; parent = parent->next) {
 143                        struct commit *p = parent->item;
 144                        if (p->object.flags & STUDYING)
 145                                continue;
 146                        p->object.flags |= STUDYING;
 147                        add_object_array(&p->object, NULL, &study);
 148                        add_object_array(&p->object, NULL, &found);
 149                }
 150        }
 151        if (!is_incomplete) {
 152                /*
 153                 * make sure all commits in "found" array have all the
 154                 * necessary objects.
 155                 */
 156                for (i = 0; i < found.nr; i++) {
 157                        struct commit *c =
 158                                (struct commit *)found.objects[i].item;
 159                        if (!tree_is_complete(c->tree->object.sha1)) {
 160                                is_incomplete = 1;
 161                                c->object.flags |= INCOMPLETE;
 162                        }
 163                }
 164                if (!is_incomplete) {
 165                        /* mark all found commits as complete, iow SEEN */
 166                        for (i = 0; i < found.nr; i++)
 167                                found.objects[i].item->flags |= SEEN;
 168                }
 169        }
 170        /* clear flags from the objects we traversed */
 171        for (i = 0; i < found.nr; i++)
 172                found.objects[i].item->flags &= ~STUDYING;
 173        if (is_incomplete)
 174                commit->object.flags |= INCOMPLETE;
 175        else {
 176                /*
 177                 * If we come here, we have (1) traversed the ancestry chain
 178                 * from the "commit" until we reach SEEN commits (which are
 179                 * known to be complete), and (2) made sure that the commits
 180                 * encountered during the above traversal refer to trees that
 181                 * are complete.  Which means that we know *all* the commits
 182                 * we have seen during this process are complete.
 183                 */
 184                for (i = 0; i < found.nr; i++)
 185                        found.objects[i].item->flags |= SEEN;
 186        }
 187        /* free object arrays */
 188        free(study.objects);
 189        free(found.objects);
 190        return !is_incomplete;
 191}
 192
 193static int keep_entry(struct commit **it, unsigned char *sha1)
 194{
 195        struct commit *commit;
 196
 197        if (is_null_sha1(sha1))
 198                return 1;
 199        commit = lookup_commit_reference_gently(sha1, 1);
 200        if (!commit)
 201                return 0;
 202
 203        /*
 204         * Make sure everything in this commit exists.
 205         *
 206         * We have walked all the objects reachable from the refs
 207         * and cache earlier.  The commits reachable by this commit
 208         * must meet SEEN commits -- and then we should mark them as
 209         * SEEN as well.
 210         */
 211        if (!commit_is_complete(commit))
 212                return 0;
 213        *it = commit;
 214        return 1;
 215}
 216
 217/*
 218 * Starting from commits in the cb->mark_list, mark commits that are
 219 * reachable from them.  Stop the traversal at commits older than
 220 * the expire_limit and queue them back, so that the caller can call
 221 * us again to restart the traversal with longer expire_limit.
 222 */
 223static void mark_reachable(struct expire_reflog_cb *cb)
 224{
 225        struct commit *commit;
 226        struct commit_list *pending;
 227        unsigned long expire_limit = cb->mark_limit;
 228        struct commit_list *leftover = NULL;
 229
 230        for (pending = cb->mark_list; pending; pending = pending->next)
 231                pending->item->object.flags &= ~REACHABLE;
 232
 233        pending = cb->mark_list;
 234        while (pending) {
 235                struct commit_list *entry = pending;
 236                struct commit_list *parent;
 237                pending = entry->next;
 238                commit = entry->item;
 239                free(entry);
 240                if (commit->object.flags & REACHABLE)
 241                        continue;
 242                if (parse_commit(commit))
 243                        continue;
 244                commit->object.flags |= REACHABLE;
 245                if (commit->date < expire_limit) {
 246                        commit_list_insert(commit, &leftover);
 247                        continue;
 248                }
 249                commit->object.flags |= REACHABLE;
 250                parent = commit->parents;
 251                while (parent) {
 252                        commit = parent->item;
 253                        parent = parent->next;
 254                        if (commit->object.flags & REACHABLE)
 255                                continue;
 256                        commit_list_insert(commit, &pending);
 257                }
 258        }
 259        cb->mark_list = leftover;
 260}
 261
 262static int unreachable(struct expire_reflog_cb *cb, struct commit *commit, unsigned char *sha1)
 263{
 264        /*
 265         * We may or may not have the commit yet - if not, look it
 266         * up using the supplied sha1.
 267         */
 268        if (!commit) {
 269                if (is_null_sha1(sha1))
 270                        return 0;
 271
 272                commit = lookup_commit_reference_gently(sha1, 1);
 273
 274                /* Not a commit -- keep it */
 275                if (!commit)
 276                        return 0;
 277        }
 278
 279        /* Reachable from the current ref?  Don't prune. */
 280        if (commit->object.flags & REACHABLE)
 281                return 0;
 282
 283        if (cb->mark_list && cb->mark_limit) {
 284                cb->mark_limit = 0; /* dig down to the root */
 285                mark_reachable(cb);
 286        }
 287
 288        return !(commit->object.flags & REACHABLE);
 289}
 290
 291static int expire_reflog_ent(unsigned char *osha1, unsigned char *nsha1,
 292                const char *email, unsigned long timestamp, int tz,
 293                const char *message, void *cb_data)
 294{
 295        struct expire_reflog_cb *cb = cb_data;
 296        struct commit *old, *new;
 297
 298        if (timestamp < cb->cmd->expire_total)
 299                goto prune;
 300
 301        if (cb->cmd->rewrite)
 302                osha1 = cb->last_kept_sha1;
 303
 304        old = new = NULL;
 305        if (cb->cmd->stalefix &&
 306            (!keep_entry(&old, osha1) || !keep_entry(&new, nsha1)))
 307                goto prune;
 308
 309        if (timestamp < cb->cmd->expire_unreachable) {
 310                if (cb->unreachable_expire_kind == UE_ALWAYS)
 311                        goto prune;
 312                if (unreachable(cb, old, osha1) || unreachable(cb, new, nsha1))
 313                        goto prune;
 314        }
 315
 316        if (cb->cmd->recno && --(cb->cmd->recno) == 0)
 317                goto prune;
 318
 319        if (cb->newlog) {
 320                char sign = (tz < 0) ? '-' : '+';
 321                int zone = (tz < 0) ? (-tz) : tz;
 322                fprintf(cb->newlog, "%s %s %s %lu %c%04d\t%s",
 323                        sha1_to_hex(osha1), sha1_to_hex(nsha1),
 324                        email, timestamp, sign, zone,
 325                        message);
 326                hashcpy(cb->last_kept_sha1, nsha1);
 327        }
 328        if (cb->cmd->verbose)
 329                printf("keep %s", message);
 330        return 0;
 331 prune:
 332        if (!cb->newlog)
 333                printf("would prune %s", message);
 334        else if (cb->cmd->verbose)
 335                printf("prune %s", message);
 336        return 0;
 337}
 338
 339static int push_tip_to_list(const char *refname, const unsigned char *sha1, int flags, void *cb_data)
 340{
 341        struct commit_list **list = cb_data;
 342        struct commit *tip_commit;
 343        if (flags & REF_ISSYMREF)
 344                return 0;
 345        tip_commit = lookup_commit_reference_gently(sha1, 1);
 346        if (!tip_commit)
 347                return 0;
 348        commit_list_insert(tip_commit, list);
 349        return 0;
 350}
 351
 352static int expire_reflog(const char *refname, const unsigned char *sha1,
 353                         struct cmd_reflog_expire_cb *cmd)
 354{
 355        static struct lock_file reflog_lock;
 356        struct expire_reflog_cb cb;
 357        struct ref_lock *lock;
 358        char *log_file;
 359        struct commit *tip_commit;
 360        struct commit_list *tips;
 361        int status = 0;
 362
 363        memset(&cb, 0, sizeof(cb));
 364
 365        /*
 366         * The reflog file is locked by holding the lock on the
 367         * reference itself, plus we might need to update the
 368         * reference if --updateref was specified:
 369         */
 370        lock = lock_any_ref_for_update(refname, sha1, 0, NULL);
 371        if (!lock)
 372                return error("cannot lock ref '%s'", refname);
 373        if (!reflog_exists(refname)) {
 374                unlock_ref(lock);
 375                return 0;
 376        }
 377
 378        log_file = git_pathdup("logs/%s", refname);
 379        if (!cmd->dry_run) {
 380                /*
 381                 * Even though holding $GIT_DIR/logs/$reflog.lock has
 382                 * no locking implications, we use the lock_file
 383                 * machinery here anyway because it does a lot of the
 384                 * work we need, including cleaning up if the program
 385                 * exits unexpectedly.
 386                 */
 387                if (hold_lock_file_for_update(&reflog_lock, log_file, 0) < 0) {
 388                        struct strbuf err = STRBUF_INIT;
 389                        unable_to_lock_message(log_file, errno, &err);
 390                        error("%s", err.buf);
 391                        strbuf_release(&err);
 392                        goto failure;
 393                }
 394                cb.newlog = fdopen_lock_file(&reflog_lock, "w");
 395                if (!cb.newlog) {
 396                        error("cannot fdopen %s (%s)",
 397                              reflog_lock.filename.buf, strerror(errno));
 398                        goto failure;
 399                }
 400        }
 401
 402        cb.cmd = cmd;
 403
 404        if (!cmd->expire_unreachable || !strcmp(refname, "HEAD")) {
 405                tip_commit = NULL;
 406                cb.unreachable_expire_kind = UE_HEAD;
 407        } else {
 408                tip_commit = lookup_commit_reference_gently(sha1, 1);
 409                if (!tip_commit)
 410                        cb.unreachable_expire_kind = UE_ALWAYS;
 411                else
 412                        cb.unreachable_expire_kind = UE_NORMAL;
 413        }
 414
 415        if (cmd->expire_unreachable <= cmd->expire_total)
 416                cb.unreachable_expire_kind = UE_ALWAYS;
 417
 418        cb.mark_list = NULL;
 419        tips = NULL;
 420        if (cb.unreachable_expire_kind != UE_ALWAYS) {
 421                if (cb.unreachable_expire_kind == UE_HEAD) {
 422                        struct commit_list *elem;
 423                        for_each_ref(push_tip_to_list, &tips);
 424                        for (elem = tips; elem; elem = elem->next)
 425                                commit_list_insert(elem->item, &cb.mark_list);
 426                } else {
 427                        commit_list_insert(tip_commit, &cb.mark_list);
 428                }
 429                cb.mark_limit = cmd->expire_total;
 430                mark_reachable(&cb);
 431        }
 432
 433        for_each_reflog_ent(refname, expire_reflog_ent, &cb);
 434
 435        if (cb.unreachable_expire_kind != UE_ALWAYS) {
 436                if (cb.unreachable_expire_kind == UE_HEAD) {
 437                        struct commit_list *elem;
 438                        for (elem = tips; elem; elem = elem->next)
 439                                clear_commit_marks(elem->item, REACHABLE);
 440                        free_commit_list(tips);
 441                } else {
 442                        clear_commit_marks(tip_commit, REACHABLE);
 443                }
 444        }
 445
 446        if (cb.newlog) {
 447                if (close_lock_file(&reflog_lock)) {
 448                        status |= error("couldn't write %s: %s", log_file,
 449                                        strerror(errno));
 450                } else if (cmd->updateref &&
 451                        (write_in_full(lock->lock_fd,
 452                                sha1_to_hex(cb.last_kept_sha1), 40) != 40 ||
 453                         write_str_in_full(lock->lock_fd, "\n") != 1 ||
 454                         close_ref(lock) < 0)) {
 455                        status |= error("couldn't write %s",
 456                                        lock->lk->filename.buf);
 457                        rollback_lock_file(&reflog_lock);
 458                } else if (commit_lock_file(&reflog_lock)) {
 459                        status |= error("unable to commit reflog '%s' (%s)",
 460                                        log_file, strerror(errno));
 461                } else if (cmd->updateref && commit_ref(lock)) {
 462                        status |= error("couldn't set %s", lock->ref_name);
 463                }
 464        }
 465        free(log_file);
 466        unlock_ref(lock);
 467        return status;
 468
 469 failure:
 470        rollback_lock_file(&reflog_lock);
 471        free(log_file);
 472        unlock_ref(lock);
 473        return -1;
 474}
 475
 476static int collect_reflog(const char *ref, const unsigned char *sha1, int unused, void *cb_data)
 477{
 478        struct collected_reflog *e;
 479        struct collect_reflog_cb *cb = cb_data;
 480        size_t namelen = strlen(ref);
 481
 482        e = xmalloc(sizeof(*e) + namelen + 1);
 483        hashcpy(e->sha1, sha1);
 484        memcpy(e->reflog, ref, namelen + 1);
 485        ALLOC_GROW(cb->e, cb->nr + 1, cb->alloc);
 486        cb->e[cb->nr++] = e;
 487        return 0;
 488}
 489
 490static struct reflog_expire_cfg {
 491        struct reflog_expire_cfg *next;
 492        unsigned long expire_total;
 493        unsigned long expire_unreachable;
 494        size_t len;
 495        char pattern[FLEX_ARRAY];
 496} *reflog_expire_cfg, **reflog_expire_cfg_tail;
 497
 498static struct reflog_expire_cfg *find_cfg_ent(const char *pattern, size_t len)
 499{
 500        struct reflog_expire_cfg *ent;
 501
 502        if (!reflog_expire_cfg_tail)
 503                reflog_expire_cfg_tail = &reflog_expire_cfg;
 504
 505        for (ent = reflog_expire_cfg; ent; ent = ent->next)
 506                if (ent->len == len &&
 507                    !memcmp(ent->pattern, pattern, len))
 508                        return ent;
 509
 510        ent = xcalloc(1, (sizeof(*ent) + len));
 511        memcpy(ent->pattern, pattern, len);
 512        ent->len = len;
 513        *reflog_expire_cfg_tail = ent;
 514        reflog_expire_cfg_tail = &(ent->next);
 515        return ent;
 516}
 517
 518static int parse_expire_cfg_value(const char *var, const char *value, unsigned long *expire)
 519{
 520        if (!value)
 521                return config_error_nonbool(var);
 522        if (parse_expiry_date(value, expire))
 523                return error(_("%s' for '%s' is not a valid timestamp"),
 524                             value, var);
 525        return 0;
 526}
 527
 528/* expiry timer slot */
 529#define EXPIRE_TOTAL   01
 530#define EXPIRE_UNREACH 02
 531
 532static int reflog_expire_config(const char *var, const char *value, void *cb)
 533{
 534        const char *pattern, *key;
 535        int pattern_len;
 536        unsigned long expire;
 537        int slot;
 538        struct reflog_expire_cfg *ent;
 539
 540        if (parse_config_key(var, "gc", &pattern, &pattern_len, &key) < 0)
 541                return git_default_config(var, value, cb);
 542
 543        if (!strcmp(key, "reflogexpire")) {
 544                slot = EXPIRE_TOTAL;
 545                if (parse_expire_cfg_value(var, value, &expire))
 546                        return -1;
 547        } else if (!strcmp(key, "reflogexpireunreachable")) {
 548                slot = EXPIRE_UNREACH;
 549                if (parse_expire_cfg_value(var, value, &expire))
 550                        return -1;
 551        } else
 552                return git_default_config(var, value, cb);
 553
 554        if (!pattern) {
 555                switch (slot) {
 556                case EXPIRE_TOTAL:
 557                        default_reflog_expire = expire;
 558                        break;
 559                case EXPIRE_UNREACH:
 560                        default_reflog_expire_unreachable = expire;
 561                        break;
 562                }
 563                return 0;
 564        }
 565
 566        ent = find_cfg_ent(pattern, pattern_len);
 567        if (!ent)
 568                return -1;
 569        switch (slot) {
 570        case EXPIRE_TOTAL:
 571                ent->expire_total = expire;
 572                break;
 573        case EXPIRE_UNREACH:
 574                ent->expire_unreachable = expire;
 575                break;
 576        }
 577        return 0;
 578}
 579
 580static void set_reflog_expiry_param(struct cmd_reflog_expire_cb *cb, int slot, const char *ref)
 581{
 582        struct reflog_expire_cfg *ent;
 583
 584        if (slot == (EXPIRE_TOTAL|EXPIRE_UNREACH))
 585                return; /* both given explicitly -- nothing to tweak */
 586
 587        for (ent = reflog_expire_cfg; ent; ent = ent->next) {
 588                if (!wildmatch(ent->pattern, ref, 0, NULL)) {
 589                        if (!(slot & EXPIRE_TOTAL))
 590                                cb->expire_total = ent->expire_total;
 591                        if (!(slot & EXPIRE_UNREACH))
 592                                cb->expire_unreachable = ent->expire_unreachable;
 593                        return;
 594                }
 595        }
 596
 597        /*
 598         * If unconfigured, make stash never expire
 599         */
 600        if (!strcmp(ref, "refs/stash")) {
 601                if (!(slot & EXPIRE_TOTAL))
 602                        cb->expire_total = 0;
 603                if (!(slot & EXPIRE_UNREACH))
 604                        cb->expire_unreachable = 0;
 605                return;
 606        }
 607
 608        /* Nothing matched -- use the default value */
 609        if (!(slot & EXPIRE_TOTAL))
 610                cb->expire_total = default_reflog_expire;
 611        if (!(slot & EXPIRE_UNREACH))
 612                cb->expire_unreachable = default_reflog_expire_unreachable;
 613}
 614
 615static int cmd_reflog_expire(int argc, const char **argv, const char *prefix)
 616{
 617        struct cmd_reflog_expire_cb cb;
 618        unsigned long now = time(NULL);
 619        int i, status, do_all;
 620        int explicit_expiry = 0;
 621
 622        default_reflog_expire_unreachable = now - 30 * 24 * 3600;
 623        default_reflog_expire = now - 90 * 24 * 3600;
 624        git_config(reflog_expire_config, NULL);
 625
 626        save_commit_buffer = 0;
 627        do_all = status = 0;
 628        memset(&cb, 0, sizeof(cb));
 629
 630        cb.expire_total = default_reflog_expire;
 631        cb.expire_unreachable = default_reflog_expire_unreachable;
 632
 633        for (i = 1; i < argc; i++) {
 634                const char *arg = argv[i];
 635                if (!strcmp(arg, "--dry-run") || !strcmp(arg, "-n"))
 636                        cb.dry_run = 1;
 637                else if (starts_with(arg, "--expire=")) {
 638                        if (parse_expiry_date(arg + 9, &cb.expire_total))
 639                                die(_("'%s' is not a valid timestamp"), arg);
 640                        explicit_expiry |= EXPIRE_TOTAL;
 641                }
 642                else if (starts_with(arg, "--expire-unreachable=")) {
 643                        if (parse_expiry_date(arg + 21, &cb.expire_unreachable))
 644                                die(_("'%s' is not a valid timestamp"), arg);
 645                        explicit_expiry |= EXPIRE_UNREACH;
 646                }
 647                else if (!strcmp(arg, "--stale-fix"))
 648                        cb.stalefix = 1;
 649                else if (!strcmp(arg, "--rewrite"))
 650                        cb.rewrite = 1;
 651                else if (!strcmp(arg, "--updateref"))
 652                        cb.updateref = 1;
 653                else if (!strcmp(arg, "--all"))
 654                        do_all = 1;
 655                else if (!strcmp(arg, "--verbose"))
 656                        cb.verbose = 1;
 657                else if (!strcmp(arg, "--")) {
 658                        i++;
 659                        break;
 660                }
 661                else if (arg[0] == '-')
 662                        usage(reflog_expire_usage);
 663                else
 664                        break;
 665        }
 666
 667        /*
 668         * We can trust the commits and objects reachable from refs
 669         * even in older repository.  We cannot trust what's reachable
 670         * from reflog if the repository was pruned with older git.
 671         */
 672        if (cb.stalefix) {
 673                init_revisions(&cb.revs, prefix);
 674                if (cb.verbose)
 675                        printf("Marking reachable objects...");
 676                mark_reachable_objects(&cb.revs, 0, 0, NULL);
 677                if (cb.verbose)
 678                        putchar('\n');
 679        }
 680
 681        if (do_all) {
 682                struct collect_reflog_cb collected;
 683                int i;
 684
 685                memset(&collected, 0, sizeof(collected));
 686                for_each_reflog(collect_reflog, &collected);
 687                for (i = 0; i < collected.nr; i++) {
 688                        struct collected_reflog *e = collected.e[i];
 689                        set_reflog_expiry_param(&cb, explicit_expiry, e->reflog);
 690                        status |= expire_reflog(e->reflog, e->sha1, &cb);
 691                        free(e);
 692                }
 693                free(collected.e);
 694        }
 695
 696        for (; i < argc; i++) {
 697                char *ref;
 698                unsigned char sha1[20];
 699                if (!dwim_log(argv[i], strlen(argv[i]), sha1, &ref)) {
 700                        status |= error("%s points nowhere!", argv[i]);
 701                        continue;
 702                }
 703                set_reflog_expiry_param(&cb, explicit_expiry, ref);
 704                status |= expire_reflog(ref, sha1, &cb);
 705        }
 706        return status;
 707}
 708
 709static int count_reflog_ent(unsigned char *osha1, unsigned char *nsha1,
 710                const char *email, unsigned long timestamp, int tz,
 711                const char *message, void *cb_data)
 712{
 713        struct cmd_reflog_expire_cb *cb = cb_data;
 714        if (!cb->expire_total || timestamp < cb->expire_total)
 715                cb->recno++;
 716        return 0;
 717}
 718
 719static int cmd_reflog_delete(int argc, const char **argv, const char *prefix)
 720{
 721        struct cmd_reflog_expire_cb cb;
 722        int i, status = 0;
 723
 724        memset(&cb, 0, sizeof(cb));
 725
 726        for (i = 1; i < argc; i++) {
 727                const char *arg = argv[i];
 728                if (!strcmp(arg, "--dry-run") || !strcmp(arg, "-n"))
 729                        cb.dry_run = 1;
 730                else if (!strcmp(arg, "--rewrite"))
 731                        cb.rewrite = 1;
 732                else if (!strcmp(arg, "--updateref"))
 733                        cb.updateref = 1;
 734                else if (!strcmp(arg, "--verbose"))
 735                        cb.verbose = 1;
 736                else if (!strcmp(arg, "--")) {
 737                        i++;
 738                        break;
 739                }
 740                else if (arg[0] == '-')
 741                        usage(reflog_delete_usage);
 742                else
 743                        break;
 744        }
 745
 746        if (argc - i < 1)
 747                return error("Nothing to delete?");
 748
 749        for ( ; i < argc; i++) {
 750                const char *spec = strstr(argv[i], "@{");
 751                unsigned char sha1[20];
 752                char *ep, *ref;
 753                int recno;
 754
 755                if (!spec) {
 756                        status |= error("Not a reflog: %s", argv[i]);
 757                        continue;
 758                }
 759
 760                if (!dwim_log(argv[i], spec - argv[i], sha1, &ref)) {
 761                        status |= error("no reflog for '%s'", argv[i]);
 762                        continue;
 763                }
 764
 765                recno = strtoul(spec + 2, &ep, 10);
 766                if (*ep == '}') {
 767                        cb.recno = -recno;
 768                        for_each_reflog_ent(ref, count_reflog_ent, &cb);
 769                } else {
 770                        cb.expire_total = approxidate(spec + 2);
 771                        for_each_reflog_ent(ref, count_reflog_ent, &cb);
 772                        cb.expire_total = 0;
 773                }
 774
 775                status |= expire_reflog(ref, sha1, &cb);
 776                free(ref);
 777        }
 778        return status;
 779}
 780
 781/*
 782 * main "reflog"
 783 */
 784
 785static const char reflog_usage[] =
 786"git reflog [ show | expire | delete ]";
 787
 788int cmd_reflog(int argc, const char **argv, const char *prefix)
 789{
 790        if (argc > 1 && !strcmp(argv[1], "-h"))
 791                usage(reflog_usage);
 792
 793        /* With no command, we default to showing it. */
 794        if (argc < 2 || *argv[1] == '-')
 795                return cmd_log_reflog(argc, argv, prefix);
 796
 797        if (!strcmp(argv[1], "show"))
 798                return cmd_log_reflog(argc - 1, argv + 1, prefix);
 799
 800        if (!strcmp(argv[1], "expire"))
 801                return cmd_reflog_expire(argc - 1, argv + 1, prefix);
 802
 803        if (!strcmp(argv[1], "delete"))
 804                return cmd_reflog_delete(argc - 1, argv + 1, prefix);
 805
 806        return cmd_log_reflog(argc, argv, prefix);
 807}