commit - 794a213ff7f2e0fada025ef53a9b5cfeecf17b94
commit + 44e1226a2053c76971c5bb2b222acf720453f866
blob - cfbcc45ff13fba2979c55762954248ea38cb65d3
blob + d10e2a92dde0841e60588804c65809e6b8dec69e
--- gotadmin/gotadmin.c
+++ gotadmin/gotadmin.c
static const struct got_error *
pack_progress(void *arg, int ncolored, int nfound, int ntrees,
off_t packfile_size, int ncommits, int nobj_total, int nobj_deltify,
- int nobj_written)
+ int nobj_written, int pack_done)
{
struct got_pack_progress_arg *a = arg;
char scaled_size[FMT_SCALED_STRSIZE];
if (print_written)
fprintf(a->out, "; writing pack: %*s %d%%",
FMT_SCALED_STRSIZE - 2, scaled_size, p_written);
- if (print_searching || print_total || print_deltify ||
- print_written) {
+ if (print_searching || print_total || print_deltify || print_written) {
a->printed_something = 1;
fflush(a->out);
}
+ if (pack_done)
+ fprintf(a->out, "\n");
return NULL;
}
static const struct got_error *
pack_index_progress(void *arg, off_t packfile_size, int nobj_total,
- int nobj_indexed, int nobj_loose, int nobj_resolved)
+ int nobj_indexed, int nobj_loose, int nobj_resolved, int indexing_done)
{
struct got_pack_progress_arg *a = arg;
char scaled_size[FMT_SCALED_STRSIZE];
printf("; indexing %d%%", p_indexed);
if (print_resolved)
printf("; resolving deltas %d%%", p_resolved);
- if (print_size || print_indexed || print_resolved)
+ if (indexing_done)
+ printf("\n");
+ if (print_size || print_indexed || print_resolved || indexing_done)
fflush(stdout);
return NULL;
struct got_repository *repo = NULL;
int ch, i, loose_obj_only = 1, force_refdelta = 0, verbosity = 0;
struct got_object_id *pack_hash = NULL;
- char *id_str = NULL;
+ char *id_str = NULL, *idxpath = NULL;
struct got_pack_progress_arg ppa;
FILE *packfile = NULL;
struct got_pathlist_head exclude_args;
if (verbosity >= 0)
printf("\nWrote %s.pack\n", id_str);
- error = got_repo_index_pack(packfile, pack_hash, repo,
+ error = got_repo_index_pack(&idxpath, packfile, pack_hash, repo,
pack_index_progress, &ppa, check_cancelled, NULL);
if (error)
goto done;
free(id_str);
free(pack_hash);
free(repo_path);
+ free(idxpath);
return error;
}
struct got_repository *repo = NULL;
int ch;
struct got_object_id *pack_hash = NULL;
- char *packfile_path = NULL;
+ char *packfile_path = NULL, *idxpath = NULL;
char *id_str = NULL;
struct got_pack_progress_arg ppa;
FILE *packfile = NULL;
if (error)
goto done;
- error = got_repo_index_pack(packfile, pack_hash, repo,
+ error = got_repo_index_pack(&idxpath, packfile, pack_hash, repo,
pack_index_progress, &ppa, check_cancelled, NULL);
if (error)
goto done;
}
free(id_str);
free(pack_hash);
+ free(idxpath);
return error;
}
int ch, dry_run = 0, verbosity = 0;
int ncommits = 0, nloose = 0, npacked = 0;
int remove_lonely_packidx = 0, ignore_mtime = 0;
+ struct got_pack_progress_arg ppa;
struct got_cleanup_progress_arg cpa;
struct got_lonely_packidx_progress_arg lpa;
off_t loose_before, loose_after;
int *pack_fds = NULL;
#ifndef PROFILE
- if (pledge("stdio rpath wpath cpath flock proc exec sendfd unveil",
+ if (pledge("stdio rpath wpath cpath fattr flock proc exec sendfd unveil",
NULL) == -1)
err(1, "pledge");
#endif
cpa.dry_run = dry_run;
cpa.verbosity = verbosity;
+ memset(&ppa, 0, sizeof(ppa));
+ ppa.out = stdout;
+ ppa.verbosity = verbosity;
+
error = got_repo_cleanup(repo, &loose_before, &loose_after,
&pack_before, &pack_after, &ncommits, &nloose, &npacked,
dry_run, ignore_mtime, cleanup_progress, &cpa,
+ pack_progress, &ppa, pack_index_progress, &ppa,
check_cancelled, NULL);
- if (cpa.printed_something)
+ if (ppa.printed_something || cpa.printed_something)
printf("\n");
if (error)
goto done;
int nobj_indexed, int nobj_loose, int nobj_resolved)
{
return pack_index_progress(arg, packfile_size, nobj_total,
- nobj_indexed, nobj_loose, nobj_resolved);
+ nobj_indexed, nobj_loose, nobj_resolved, 0);
}
static int
blob - 005ac26ea90a4ddbfb4e9ef59c2007a0c7ea6a28
blob + 624ed22ece2533f6578595fc15704a94da83421e
--- gotd/repo_read.c
+++ gotd/repo_read.c
static const struct got_error *
pack_progress(void *arg, int ncolored, int nfound, int ntrees,
off_t packfile_size, int ncommits, int nobj_total, int nobj_deltify,
- int nobj_written)
+ int nobj_written, int pack_done)
{
struct repo_read_pack_progress_arg *a = arg;
struct gotd_imsg_packfile_progress iprog;
blob - a1bb191618ec66c76deecf76d52349088c755a06
blob + 41b7e6bd3ec9d8b9aef83734da5dfe17ea860f28
--- include/got_repository_admin.h
+++ include/got_repository_admin.h
/* A callback function which gets invoked with progress information to print. */
typedef const struct got_error *(*got_pack_progress_cb)(void *arg,
int ncolored, int nfound, int ntrees, off_t packfile_size, int ncommits,
- int nobj_total, int obj_deltify, int nobj_written);
+ int nobj_total, int obj_deltify, int nobj_written, int pack_done);
/*
* Attempt to pack objects reachable via 'include_refs' into a new packfile.
/* A callback function which gets invoked with progress information to print. */
typedef const struct got_error *(*got_pack_index_progress_cb)(void *arg,
off_t packfile_size, int nobj_total, int nobj_indexed,
- int nobj_loose, int nobj_resolved);
+ int nobj_loose, int nobj_resolved, int indexing_done);
/* (Re-)Index the pack file identified by the given hash. */
const struct got_error *
-got_repo_index_pack(FILE *packfile, struct got_object_id *pack_hash,
- struct got_repository *repo,
+got_repo_index_pack(char **idxpath, FILE *packfile,
+ struct got_object_id *pack_hash, struct got_repository *repo,
got_pack_index_progress_cb progress_cb, void *progress_arg,
got_cancel_cb cancel_cb, void *cancel_arg);
int ncommits, int nloose, int npurged, int nredundant);
/*
- * Walk objects reachable via references to determine whether any loose
- * objects can be removed from disk. Do remove such objects from disk
- * unless the dry_run parameter is set.
+ * Walk objects reachable via references and, unless the dry-run parameter
+ * is set, pack all referenced objects into a single pack.
+ * Then determine whether any loose objects can be removed from disk.
+ * Do remove such objects from disk unless the dry_run parameter is set.
* Do not remove objects with a modification timestamp above an
* implementation-defined timestamp threshold, unless ignore_mtime is set.
* Remove packfiles which objects are either unreachable or provided
int *ncommits, int *nloose,
int *npacked, int dry_run, int ignore_mtime,
got_cleanup_progress_cb progress_cb, void *progress_arg,
+ got_pack_progress_cb pack_progress_cb, void *pack_progress_arg,
+ got_pack_index_progress_cb index_progress_cb, void *index_progress_arg,
got_cancel_cb cancel_cb, void *cancel_arg);
/* A callback function which gets invoked with cleanup information to print. */
blob - 8bf80e3bec6bdb3edf09b007a268b9fb8eb96d0b
blob + 265d2bf372d90b0b2c3c124b8d9885056f6f1250
--- lib/got_lib_pack_create.h
+++ lib/got_lib_pack_create.h
got_pack_report_progress(got_pack_progress_cb progress_cb, void *progress_arg,
struct got_ratelimit *rl, int ncolored, int nfound, int ntrees,
off_t packfile_size, int ncommits, int nobj_total, int obj_deltify,
- int nobj_written);
+ int nobj_written, int pack_done);
const struct got_error *
got_pack_load_packed_object_ids(int *found_all_objects,
blob - 2c1af75785bf1df55c1b4996d7ddbb5ffc0dd2c1
blob + f69fe8b0f0d9292efbd835da4ba3669bdceff718
--- lib/pack_create.c
+++ lib/pack_create.c
got_pack_report_progress(got_pack_progress_cb progress_cb, void *progress_arg,
struct got_ratelimit *rl, int ncolored, int nfound, int ntrees,
off_t packfile_size, int ncommits, int nobj_total, int obj_deltify,
- int nobj_written)
+ int nobj_written, int pack_done)
{
const struct got_error *err;
int elapsed;
return err;
return progress_cb(progress_arg, ncolored, nfound, ntrees,
- packfile_size, ncommits, nobj_total, obj_deltify, nobj_written);
+ packfile_size, ncommits, nobj_total, obj_deltify, nobj_written,
+ pack_done);
}
const struct got_error *
}
err = got_pack_report_progress(progress_cb, progress_arg, rl,
ncolored, nfound, ntrees, 0L, ncommits, nreused + nmeta,
- nreused + i, 0);
+ nreused + i, 0, 0);
if (err)
goto done;
m = meta[i];
(*nfound)++;
err = got_pack_report_progress(progress_cb, progress_arg, rl,
- *ncolored, *nfound, *ntrees, 0L, 0, 0, 0, 0);
+ *ncolored, *nfound, *ntrees, 0L, 0, 0, 0, 0, 0);
if (err) {
clear_meta(m);
free(m);
(*ntrees)++;
err = got_pack_report_progress(progress_cb, progress_arg, rl,
- *ncolored, *nfound, *ntrees, 0L, 0, 0, 0, 0);
+ *ncolored, *nfound, *ntrees, 0L, 0, 0, 0, 0, 0);
if (err)
return err;
for (i = 0; i < ndeltify; i++) {
err = got_pack_report_progress(progress_cb, progress_arg, rl,
ncolored, nfound, ntrees, packfile_size, nours,
- ndeltify + nreuse, ndeltify + nreuse, i);
+ ndeltify + nreuse, ndeltify + nreuse, i, 0);
if (err)
goto done;
m = deltify[i];
for (i = 0; i < nreuse; i++) {
err = got_pack_report_progress(progress_cb, progress_arg, rl,
ncolored, nfound, ntrees, packfile_size, nours,
- ndeltify + nreuse, ndeltify + nreuse, ndeltify + i);
+ ndeltify + nreuse, ndeltify + nreuse, ndeltify + i, 0);
if (err)
goto done;
m = reuse[i];
if (progress_cb) {
err = progress_cb(progress_arg, ncolored, nfound, ntrees,
packfile_size, nours, ndeltify + nreuse,
- ndeltify + nreuse, ndeltify + nreuse);
+ ndeltify + nreuse, ndeltify + nreuse, 1);
if (err)
goto done;
}
if (progress_cb) {
err = progress_cb(progress_arg, ncolored, nfound, ntrees,
- 0L, nours, got_object_idset_num_elements(idset), 0, 0);
+ 0L, nours, got_object_idset_num_elements(idset), 0, 0, 0);
if (err)
goto done;
}
err = progress_cb(progress_arg, ncolored, nfound, ntrees,
1 /* packfile_size */, nours,
got_object_idset_num_elements(idset),
- deltify.nmeta + reuse.nmeta, 0);
+ deltify.nmeta + reuse.nmeta, 0, 0);
if (err)
goto done;
}
blob - 6eaae896b14e139387beeb9e91d194e79f260540
blob + 50fcf48fcebe173324fc948ae4d733cb77564b5d
--- lib/pack_create_io.c
+++ lib/pack_create_io.c
err = got_pack_report_progress(a->progress_cb, a->progress_arg,
a->rl, a->ncolored, a->nfound, a->ntrees, 0L, a->ncommits,
- got_object_idset_num_elements(a->idset), a->v->nmeta, 0);
+ got_object_idset_num_elements(a->idset), a->v->nmeta, 0, 0);
if (err)
goto done;
}
}
err = got_pack_report_progress(progress_cb, progress_arg, rl,
- *ncolored, 0, 0, 0L, 0, 0, 0, 0);
+ *ncolored, 0, 0, 0L, 0, 0, 0, 0, 0);
if (err)
break;
blob - 43c97d13ee5b5cd39eca25694ad73100a288e11c
blob + db73fef0419f5e2e739953b796b27d540a11c841
--- lib/pack_create_privsep.c
+++ lib/pack_create_privsep.c
err = got_pack_report_progress(progress_cb, progress_arg, rl,
ncolored, nfound, ntrees, 0L, ncommits,
- got_object_idset_num_elements(idset), v->nmeta, 0);
+ got_object_idset_num_elements(idset), v->nmeta, 0, 0);
if (err)
break;
}
}
return got_pack_report_progress(a->progress_cb, a->progress_arg, a->rl,
- *a->ncolored, 0, 0, 0L, 0, 0, 0, 0);
+ *a->ncolored, 0, 0, 0L, 0, 0, 0, 0, 0);
}
static const struct got_error *
}
err = got_pack_report_progress(progress_cb, progress_arg, rl,
- *ncolored, 0, 0, 0L, 0, 0, 0, 0);
+ *ncolored, 0, 0, 0L, 0, 0, 0, 0, 0);
if (err)
break;
blob - 8e01a1ea9f188da82bd593b97dc130ca55f4986b
blob + aed0ab8b6184bc0a8594af6b2dd77d8d856d88df
--- lib/repository_admin.c
+++ lib/repository_admin.c
return err;
}
+static const struct got_error *
+create_temp_packfile(int *packfd, char **tmpfile_path,
+ struct got_repository *repo)
+{
+ const struct got_error *err = NULL;
+ char *path;
+
+ *packfd = -1;
+
+ if (asprintf(&path, "%s/%s/packing.pack",
+ got_repo_get_path_git_dir(repo), GOT_OBJECTS_PACK_DIR) == -1)
+ return got_error_from_errno("asprintf");
+
+ err = got_opentemp_named_fd(tmpfile_path, packfd, path, "");
+ if (err)
+ goto done;
+
+ if (fchmod(*packfd, GOT_DEFAULT_PACK_MODE) == -1)
+ err = got_error_from_errno2("fchmod", *tmpfile_path);
+done:
+ if (err) {
+ close(*packfd);
+ *packfd = -1;
+ free(*tmpfile_path);
+ *tmpfile_path = NULL;
+ }
+ return err;
+}
+
+static const struct got_error *
+install_packfile(FILE **packfile, int *packfd, char **packfile_path,
+ char **tmpfile_path, struct got_object_id *pack_hash,
+ struct got_repository *repo)
+{
+ const struct got_error *err;
+ char *hash_str;
+
+ err = got_object_id_str(&hash_str, pack_hash);
+ if (err)
+ return err;
+
+ if (asprintf(packfile_path, "%s/%s/pack-%s.pack",
+ got_repo_get_path_git_dir(repo), GOT_OBJECTS_PACK_DIR,
+ hash_str) == -1) {
+ err = got_error_from_errno("asprintf");
+ goto done;
+ }
+
+ if (lseek(*packfd, 0L, SEEK_SET) == -1) {
+ err = got_error_from_errno("lseek");
+ goto done;
+ }
+
+ if (rename(*tmpfile_path, *packfile_path) == -1) {
+ err = got_error_from_errno3("rename", *tmpfile_path,
+ *packfile_path);
+ goto done;
+ }
+
+ free(*tmpfile_path);
+ *tmpfile_path = NULL;
+
+ *packfile = fdopen(*packfd, "w");
+ if (*packfile == NULL) {
+ err = got_error_from_errno2("fdopen", *packfile_path);
+ goto done;
+ }
+ *packfd = -1;
+done:
+ free(hash_str);
+ return err;
+}
+
const struct got_error *
got_repo_pack_objects(FILE **packfile, struct got_object_id **pack_hash,
struct got_reflist_head *include_refs,
const struct got_error *err = NULL;
struct got_object_id **ours = NULL, **theirs = NULL;
int nours = 0, ntheirs = 0, packfd = -1, i;
- char *tmpfile_path = NULL, *path = NULL, *packfile_path = NULL;
- char *hash_str = NULL;
+ char *tmpfile_path = NULL, *packfile_path = NULL;
FILE *delta_cache = NULL;
struct got_ratelimit rl;
got_ratelimit_init(&rl, 0, 500);
- if (asprintf(&path, "%s/%s/packing.pack",
- got_repo_get_path_git_dir(repo), GOT_OBJECTS_PACK_DIR) == -1) {
- err = got_error_from_errno("asprintf");
- goto done;
- }
- err = got_opentemp_named_fd(&tmpfile_path, &packfd, path, "");
+ err = create_temp_packfile(&packfd, &tmpfile_path, repo);
if (err)
- goto done;
+ return err;
- if (fchmod(packfd, GOT_DEFAULT_PACK_MODE) == -1) {
- err = got_error_from_errno2("fchmod", tmpfile_path);
- goto done;
- }
-
delta_cache = got_opentemp();
if (delta_cache == NULL) {
err = got_error_from_errno("got_opentemp");
if (err)
goto done;
- err = got_object_id_str(&hash_str, *pack_hash);
- if (err)
- goto done;
- if (asprintf(&packfile_path, "%s/%s/pack-%s.pack",
- got_repo_get_path_git_dir(repo), GOT_OBJECTS_PACK_DIR,
- hash_str) == -1) {
- err = got_error_from_errno("asprintf");
- goto done;
- }
-
- if (lseek(packfd, 0L, SEEK_SET) == -1) {
- err = got_error_from_errno("lseek");
- goto done;
- }
- if (rename(tmpfile_path, packfile_path) == -1) {
- err = got_error_from_errno3("rename", tmpfile_path,
- packfile_path);
- goto done;
- }
- free(tmpfile_path);
- tmpfile_path = NULL;
-
- *packfile = fdopen(packfd, "w");
- if (*packfile == NULL) {
- err = got_error_from_errno2("fdopen", tmpfile_path);
- goto done;
- }
- packfd = -1;
+ err = install_packfile(packfile, &packfd, &packfile_path,
+ &tmpfile_path, *pack_hash, repo);
done:
for (i = 0; i < nours; i++)
free(ours[i]);
err = got_error_from_errno2("unlink", tmpfile_path);
free(tmpfile_path);
free(packfile_path);
- free(hash_str);
- free(path);
if (err) {
free(*pack_hash);
*pack_hash = NULL;
}
const struct got_error *
-got_repo_index_pack(FILE *packfile, struct got_object_id *pack_hash,
- struct got_repository *repo,
+got_repo_index_pack(char **idxpath, FILE *packfile,
+ struct got_object_id *pack_hash, struct got_repository *repo,
got_pack_index_progress_cb progress_cb, void *progress_arg,
got_cancel_cb cancel_cb, void *cancel_arg)
{
int npackfd = -1, idxfd = -1, nidxfd = -1;
int tmpfds[3];
int idxstatus, done = 0;
+ int nobj_total = 0, nobj_indexed = 0, nobj_loose = 0, nobj_resolved = 0;
const struct got_error *err;
struct imsgbuf idxibuf;
pid_t idxpid;
char *tmpidxpath = NULL;
- char *packfile_path = NULL, *idxpath = NULL, *id_str = NULL;
+ char *packfile_path = NULL, *id_str = NULL;
const char *repo_path = got_repo_get_path_git_dir(repo);
struct stat sb;
+ *idxpath = NULL;
memset(&idxibuf, 0, sizeof(idxibuf));
for (i = 0; i < nitems(tmpfds); i++)
goto done;
}
- if (asprintf(&idxpath, "%s/%s/pack-%s.idx",
+ if (asprintf(idxpath, "%s/%s/pack-%s.idx",
repo_path, GOT_OBJECTS_PACK_DIR, id_str) == -1) {
err = got_error_from_errno("asprintf");
goto done;
}
done = 0;
while (!done) {
- int nobj_total, nobj_indexed, nobj_loose, nobj_resolved;
-
if (cancel_cb) {
err = cancel_cb(cancel_arg);
if (err)
if (nobj_indexed != 0) {
err = progress_cb(progress_arg, sb.st_size,
nobj_total, nobj_indexed, nobj_loose,
- nobj_resolved);
+ nobj_resolved, 0);
if (err)
break;
}
}
+ if (done) {
+ err = progress_cb(progress_arg, sb.st_size,
+ nobj_total, nobj_indexed, nobj_loose,
+ nobj_resolved, done);
+ if (err)
+ goto done;
+ }
if (close(imsg_idxfds[0]) == -1) {
err = got_error_from_errno("close");
goto done;
goto done;
}
- if (rename(tmpidxpath, idxpath) == -1) {
- err = got_error_from_errno3("rename", tmpidxpath, idxpath);
+ if (rename(tmpidxpath, *idxpath) == -1) {
+ err = got_error_from_errno3("rename", tmpidxpath, *idxpath);
goto done;
}
free(tmpidxpath);
err = got_error_from_errno("close");
}
free(tmpidxpath);
- free(idxpath);
free(packfile_path);
return err;
}
off_t *pack_before, off_t *pack_after,
int *ncommits, int *nloose, int *npacked, int dry_run, int ignore_mtime,
got_cleanup_progress_cb progress_cb, void *progress_arg,
+ got_pack_progress_cb pack_progress_cb, void *pack_progress_arg,
+ got_pack_index_progress_cb index_progress_cb, void *index_progress_arg,
got_cancel_cb cancel_cb, void *cancel_arg)
{
const struct got_error *unlock_err, *err = NULL;
struct got_reflist_entry *re;
struct got_object_id **referenced_ids;
int i, nreferenced;
- int npurged = 0;
+ int npurged = 0, packfd = -1;
+ char *tmpfile_path = NULL, *packfile_path = NULL, *idxpath = NULL;
+ FILE *delta_cache = NULL, *packfile = NULL;
+ struct got_object_id pack_hash;
time_t max_mtime = 0;
TAILQ_INIT(&refs);
got_ratelimit_init(&rl, 0, 500);
+ memset(&pack_hash, 0, sizeof(pack_hash));
*loose_before = 0;
*loose_after = 0;
if (err)
return err;
+ err = create_temp_packfile(&packfd, &tmpfile_path, repo);
+ if (err)
+ goto done;
+
+ delta_cache = got_opentemp();
+ if (delta_cache == NULL) {
+ err = got_error_from_errno("got_opentemp");
+ goto done;
+ }
+
traversed_ids = got_object_idset_alloc();
if (traversed_ids == NULL) {
err = got_error_from_errno("got_object_idset_alloc");
goto done;
}
+ err = got_pack_create(&pack_hash, packfd, delta_cache,
+ NULL, 0, referenced_ids, nreferenced, repo, 0,
+ 0, 0, pack_progress_cb, pack_progress_arg,
+ &rl, cancel_cb, cancel_arg);
+ if (err)
+ goto done;
+
+ err = install_packfile(&packfile, &packfd, &packfile_path,
+ &tmpfile_path, &pack_hash, repo);
+ if (err)
+ goto done;
+
+ err = got_repo_index_pack(&idxpath, packfile, &pack_hash, repo,
+ index_progress_cb, index_progress_arg,
+ cancel_cb, cancel_arg);
+ if (err)
+ goto done;
+
+ err = got_repo_list_packidx(&repo->packidx_paths, repo);
+ if (err)
+ goto done;
+
err = repo_purge_unreferenced_loose_objects(repo, traversed_ids,
loose_before, loose_after, *ncommits, nloose, npacked, &npurged,
dry_run, ignore_mtime, max_mtime, &rl, progress_cb, progress_arg,
if (err)
goto done;
+ if (dry_run) {
+ if (idxpath && unlink(idxpath) == -1)
+ err = got_error_from_errno2("unlink", idxpath);
+ if (packfile_path && unlink(packfile_path) == -1 && err == NULL)
+ err = got_error_from_errno2("unlink", packfile_path);
+ }
done:
if (lk) {
unlock_err = got_lockfile_unlock(lk, got_repo_get_fd(repo));
}
if (traversed_ids)
got_object_idset_free(traversed_ids);
+ if (packfd != -1 && close(packfd) == -1 && err == NULL)
+ err = got_error_from_errno2("close", packfile_path);
+ if (delta_cache && fclose(delta_cache) == EOF && err == NULL)
+ err = got_error_from_errno("fclose");
+ if (tmpfile_path && unlink(tmpfile_path) == -1 && err == NULL)
+ err = got_error_from_errno2("unlink", tmpfile_path);
+ free(tmpfile_path);
+ free(packfile_path);
+ free(idxpath);
return err;
}
blob - c921af09ce0ec19b005e3d915225299721c2f81f
blob + 805b395066961cc2893ecbb2132559c999f43ece
--- lib/send.c
+++ lib/send.c
static const struct got_error *
pack_progress(void *arg, int ncolored, int nfound, int ntrees,
off_t packfile_size, int ncommits, int nobj_total, int nobj_deltify,
- int nobj_written)
+ int nobj_written, int pack_done)
{
const struct got_error *err;
struct pack_progress_arg *a = arg;
blob - 00f32bb02afd89bd6cb1db91f4b9385e33bd5617
blob + f4099794bb7ebc53f96a1addc9b3d92c43e8c93d
--- regress/cmdline/cleanup.sh
+++ regress/cmdline/cleanup.sh
return 1
fi
- # cleanup should remove loose objects that belonged to the branch
+ # cleanup should remove all loose objects
gotadmin cleanup -a -q -r $testroot/repo > $testroot/stdout
ret=$?
if [ $ret -ne 0 ]; then
nloose2=`gotadmin info -r $testroot/repo | grep '^loose objects:' | \
cut -d ':' -f 2 | tr -d ' '`
- if [ "$nloose2" != "$nloose0" ]; then
+ if [ "$nloose2" != "0" ]; then
echo "unexpected number of loose objects: $nloose2" >&2
test_done "$testroot" "1"
return 1
gotadmin cleanup -a -q -r "$testroot/repo"
n=$(gotadmin info -r "$testroot/repo" | awk '/^pack files/{print $3}')
- if [ "$n" -ne 3 ]; then
- echo "expected 3 pack files left, $n found instead" >&2
+ if [ "$n" -ne 2 ]; then
+ echo "expected 2 pack files left, $n found instead" >&2
test_done "$testroot" 1
return 1
fi
gotadmin cleanup -a -q -r "$testroot/repo"
n=$(gotadmin info -r "$testroot/repo" | awk '/^pack files/{print $3}')
- if [ "$n" -ne 3 ]; then
- echo "expected 3 pack files left, $n found instead" >&2
+ if [ "$n" -ne 1 ]; then
+ echo "expected 1 pack files left, $n found instead" >&2
test_done "$testroot" 1
return 1
fi
blob - e606991123823035db24ea363dd8e9e0250df81b
blob + 9a199b109499e4e13271e33d51016fdef2dda3b7
--- regress/cmdline/common.sh
+++ regress/cmdline/common.sh
local testroot="$1"
local repo="$2"
- git -C $repo fsck --strict \
+ git -C $repo fsck --strict --no-reflogs \
> $testroot/fsck.stdout 2> $testroot/fsck.stderr
ret=$?
if [ $ret -ne 0 ]; then
