Blame src/pack-objects.c

Packit ae9e2a
/*
Packit ae9e2a
 * Copyright (C) the libgit2 contributors. All rights reserved.
Packit ae9e2a
 *
Packit ae9e2a
 * This file is part of libgit2, distributed under the GNU GPL v2 with
Packit ae9e2a
 * a Linking Exception. For full terms see the included COPYING file.
Packit ae9e2a
 */
Packit ae9e2a
Packit ae9e2a
#include "pack-objects.h"
Packit ae9e2a
Packit ae9e2a
#include "zstream.h"
Packit ae9e2a
#include "delta.h"
Packit ae9e2a
#include "iterator.h"
Packit ae9e2a
#include "netops.h"
Packit ae9e2a
#include "pack.h"
Packit ae9e2a
#include "thread-utils.h"
Packit ae9e2a
#include "tree.h"
Packit ae9e2a
#include "util.h"
Packit ae9e2a
#include "revwalk.h"
Packit ae9e2a
#include "commit_list.h"
Packit ae9e2a
Packit ae9e2a
#include "git2/pack.h"
Packit ae9e2a
#include "git2/commit.h"
Packit ae9e2a
#include "git2/tag.h"
Packit ae9e2a
#include "git2/indexer.h"
Packit ae9e2a
#include "git2/config.h"
Packit ae9e2a
Packit ae9e2a
struct unpacked {
Packit ae9e2a
	git_pobject *object;
Packit ae9e2a
	void *data;
Packit ae9e2a
	struct git_delta_index *index;
Packit ae9e2a
	size_t depth;
Packit ae9e2a
};
Packit ae9e2a
Packit ae9e2a
struct tree_walk_context {
Packit ae9e2a
	git_packbuilder *pb;
Packit ae9e2a
	git_buf buf;
Packit ae9e2a
};
Packit ae9e2a
Packit ae9e2a
struct pack_write_context {
Packit ae9e2a
	git_indexer *indexer;
Packit ae9e2a
	git_transfer_progress *stats;
Packit ae9e2a
};
Packit ae9e2a
Packit ae9e2a
#ifdef GIT_THREADS
Packit ae9e2a
Packit ae9e2a
#define GIT_PACKBUILDER__MUTEX_OP(pb, mtx, op) do { \
Packit ae9e2a
		int result = git_mutex_##op(&(pb)->mtx); \
Packit ae9e2a
		assert(!result); \
Packit ae9e2a
		GIT_UNUSED(result); \
Packit ae9e2a
	} while (0)
Packit ae9e2a
Packit ae9e2a
#else
Packit ae9e2a
Packit ae9e2a
#define GIT_PACKBUILDER__MUTEX_OP(pb,mtx,op) GIT_UNUSED(pb)
Packit ae9e2a
Packit ae9e2a
#endif /* GIT_THREADS */
Packit ae9e2a
Packit ae9e2a
#define git_packbuilder__cache_lock(pb) GIT_PACKBUILDER__MUTEX_OP(pb, cache_mutex, lock)
Packit ae9e2a
#define git_packbuilder__cache_unlock(pb) GIT_PACKBUILDER__MUTEX_OP(pb, cache_mutex, unlock)
Packit ae9e2a
#define git_packbuilder__progress_lock(pb) GIT_PACKBUILDER__MUTEX_OP(pb, progress_mutex, lock)
Packit ae9e2a
#define git_packbuilder__progress_unlock(pb) GIT_PACKBUILDER__MUTEX_OP(pb, progress_mutex, unlock)
Packit ae9e2a
Packit ae9e2a
/* The minimal interval between progress updates (in seconds). */
Packit ae9e2a
#define MIN_PROGRESS_UPDATE_INTERVAL 0.5
Packit ae9e2a
Packit ae9e2a
/* Size of the buffer to feed to zlib */
Packit ae9e2a
#define COMPRESS_BUFLEN (1024 * 1024)
Packit ae9e2a
Packit ae9e2a
static unsigned name_hash(const char *name)
Packit ae9e2a
{
Packit ae9e2a
	unsigned c, hash = 0;
Packit ae9e2a
Packit ae9e2a
	if (!name)
Packit ae9e2a
		return 0;
Packit ae9e2a
Packit ae9e2a
	/*
Packit ae9e2a
	 * This effectively just creates a sortable number from the
Packit ae9e2a
	 * last sixteen non-whitespace characters. Last characters
Packit ae9e2a
	 * count "most", so things that end in ".c" sort together.
Packit ae9e2a
	 */
Packit ae9e2a
	while ((c = *name++) != 0) {
Packit ae9e2a
		if (git__isspace(c))
Packit ae9e2a
			continue;
Packit ae9e2a
		hash = (hash >> 2) + (c << 24);
Packit ae9e2a
	}
Packit ae9e2a
	return hash;
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
static int packbuilder_config(git_packbuilder *pb)
Packit ae9e2a
{
Packit ae9e2a
	git_config *config;
Packit ae9e2a
	int ret = 0;
Packit ae9e2a
	int64_t val;
Packit ae9e2a
Packit ae9e2a
	if ((ret = git_repository_config_snapshot(&config, pb->repo)) < 0)
Packit ae9e2a
		return ret;
Packit ae9e2a
Packit ae9e2a
#define config_get(KEY,DST,DFLT) do { \
Packit ae9e2a
	ret = git_config_get_int64(&val, config, KEY); \
Packit ae9e2a
	if (!ret) { \
Packit ae9e2a
		if (!git__is_sizet(val)) { \
Packit ae9e2a
			giterr_set(GITERR_CONFIG, \
Packit ae9e2a
				"configuration value '%s' is too large", KEY); \
Packit ae9e2a
			ret = -1; \
Packit ae9e2a
			goto out; \
Packit ae9e2a
		} \
Packit ae9e2a
		(DST) = (size_t)val; \
Packit ae9e2a
	} else if (ret == GIT_ENOTFOUND) { \
Packit ae9e2a
	    (DST) = (DFLT); \
Packit ae9e2a
	    ret = 0; \
Packit ae9e2a
	} else if (ret < 0) goto out; } while (0)
Packit ae9e2a
Packit ae9e2a
	config_get("pack.deltaCacheSize", pb->max_delta_cache_size,
Packit ae9e2a
		   GIT_PACK_DELTA_CACHE_SIZE);
Packit ae9e2a
	config_get("pack.deltaCacheLimit", pb->cache_max_small_delta_size,
Packit ae9e2a
		   GIT_PACK_DELTA_CACHE_LIMIT);
Packit ae9e2a
	config_get("pack.deltaCacheSize", pb->big_file_threshold,
Packit ae9e2a
		   GIT_PACK_BIG_FILE_THRESHOLD);
Packit ae9e2a
	config_get("pack.windowMemory", pb->window_memory_limit, 0);
Packit ae9e2a
Packit ae9e2a
#undef config_get
Packit ae9e2a
Packit ae9e2a
out:
Packit ae9e2a
	git_config_free(config);
Packit ae9e2a
Packit ae9e2a
	return ret;
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
int git_packbuilder_new(git_packbuilder **out, git_repository *repo)
Packit ae9e2a
{
Packit ae9e2a
	git_packbuilder *pb;
Packit ae9e2a
Packit ae9e2a
	*out = NULL;
Packit ae9e2a
Packit ae9e2a
	pb = git__calloc(1, sizeof(*pb));
Packit ae9e2a
	GITERR_CHECK_ALLOC(pb);
Packit ae9e2a
Packit ae9e2a
	pb->object_ix = git_oidmap_alloc();
Packit ae9e2a
	if (!pb->object_ix)
Packit ae9e2a
		goto on_error;
Packit ae9e2a
Packit ae9e2a
	pb->walk_objects = git_oidmap_alloc();
Packit ae9e2a
	if (!pb->walk_objects)
Packit ae9e2a
		goto on_error;
Packit ae9e2a
Packit ae9e2a
	git_pool_init(&pb->object_pool, sizeof(git_walk_object));
Packit ae9e2a
Packit ae9e2a
	pb->repo = repo;
Packit ae9e2a
	pb->nr_threads = 1; /* do not spawn any thread by default */
Packit ae9e2a
Packit ae9e2a
	if (git_hash_ctx_init(&pb->ctx) < 0 ||
Packit ae9e2a
		git_zstream_init(&pb->zstream, GIT_ZSTREAM_DEFLATE) < 0 ||
Packit ae9e2a
		git_repository_odb(&pb->odb, repo) < 0 ||
Packit ae9e2a
		packbuilder_config(pb) < 0)
Packit ae9e2a
		goto on_error;
Packit ae9e2a
Packit ae9e2a
#ifdef GIT_THREADS
Packit ae9e2a
Packit ae9e2a
	if (git_mutex_init(&pb->cache_mutex) ||
Packit ae9e2a
		git_mutex_init(&pb->progress_mutex) ||
Packit ae9e2a
		git_cond_init(&pb->progress_cond))
Packit ae9e2a
	{
Packit ae9e2a
		giterr_set(GITERR_OS, "failed to initialize packbuilder mutex");
Packit ae9e2a
		goto on_error;
Packit ae9e2a
	}
Packit ae9e2a
Packit ae9e2a
#endif
Packit ae9e2a
Packit ae9e2a
	*out = pb;
Packit ae9e2a
	return 0;
Packit ae9e2a
Packit ae9e2a
on_error:
Packit ae9e2a
	git_packbuilder_free(pb);
Packit ae9e2a
	return -1;
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
unsigned int git_packbuilder_set_threads(git_packbuilder *pb, unsigned int n)
Packit ae9e2a
{
Packit ae9e2a
	assert(pb);
Packit ae9e2a
Packit ae9e2a
#ifdef GIT_THREADS
Packit ae9e2a
	pb->nr_threads = n;
Packit ae9e2a
#else
Packit ae9e2a
	GIT_UNUSED(n);
Packit ae9e2a
	assert(1 == pb->nr_threads);
Packit ae9e2a
#endif
Packit ae9e2a
Packit ae9e2a
	return pb->nr_threads;
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
static void rehash(git_packbuilder *pb)
Packit ae9e2a
{
Packit ae9e2a
	git_pobject *po;
Packit ae9e2a
	khiter_t pos;
Packit ae9e2a
	size_t i;
Packit ae9e2a
	int ret;
Packit ae9e2a
Packit ae9e2a
	git_oidmap_clear(pb->object_ix);
Packit ae9e2a
	for (i = 0, po = pb->object_list; i < pb->nr_objects; i++, po++) {
Packit ae9e2a
		pos = git_oidmap_put(pb->object_ix, &po->id, &ret;;
Packit ae9e2a
		git_oidmap_set_value_at(pb->object_ix, pos, po);
Packit ae9e2a
	}
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
int git_packbuilder_insert(git_packbuilder *pb, const git_oid *oid,
Packit ae9e2a
			   const char *name)
Packit ae9e2a
{
Packit ae9e2a
	git_pobject *po;
Packit ae9e2a
	khiter_t pos;
Packit ae9e2a
	size_t newsize;
Packit ae9e2a
	int ret;
Packit ae9e2a
Packit ae9e2a
	assert(pb && oid);
Packit ae9e2a
Packit ae9e2a
	/* If the object already exists in the hash table, then we don't
Packit ae9e2a
	 * have any work to do */
Packit ae9e2a
	if (git_oidmap_exists(pb->object_ix, oid))
Packit ae9e2a
		return 0;
Packit ae9e2a
Packit ae9e2a
	if (pb->nr_objects >= pb->nr_alloc) {
Packit ae9e2a
		GITERR_CHECK_ALLOC_ADD(&newsize, pb->nr_alloc, 1024);
Packit ae9e2a
		GITERR_CHECK_ALLOC_MULTIPLY(&newsize, newsize, 3 / 2);
Packit ae9e2a
Packit ae9e2a
		if (!git__is_uint32(newsize)) {
Packit ae9e2a
			giterr_set(GITERR_NOMEMORY, "packfile too large to fit in memory.");
Packit ae9e2a
			return -1;
Packit ae9e2a
		}
Packit ae9e2a
Packit ae9e2a
		pb->nr_alloc = newsize;
Packit ae9e2a
Packit ae9e2a
		pb->object_list = git__reallocarray(pb->object_list,
Packit ae9e2a
			pb->nr_alloc, sizeof(*po));
Packit ae9e2a
		GITERR_CHECK_ALLOC(pb->object_list);
Packit ae9e2a
		rehash(pb);
Packit ae9e2a
	}
Packit ae9e2a
Packit ae9e2a
	po = pb->object_list + pb->nr_objects;
Packit ae9e2a
	memset(po, 0x0, sizeof(*po));
Packit ae9e2a
Packit ae9e2a
	if ((ret = git_odb_read_header(&po->size, &po->type, pb->odb, oid)) < 0)
Packit ae9e2a
		return ret;
Packit ae9e2a
Packit ae9e2a
	pb->nr_objects++;
Packit ae9e2a
	git_oid_cpy(&po->id, oid);
Packit ae9e2a
	po->hash = name_hash(name);
Packit ae9e2a
Packit ae9e2a
	pos = git_oidmap_put(pb->object_ix, &po->id, &ret;;
Packit ae9e2a
	if (ret < 0) {
Packit ae9e2a
		giterr_set_oom();
Packit ae9e2a
		return ret;
Packit ae9e2a
	}
Packit ae9e2a
	assert(ret != 0);
Packit ae9e2a
	git_oidmap_set_value_at(pb->object_ix, pos, po);
Packit ae9e2a
Packit ae9e2a
	pb->done = false;
Packit ae9e2a
Packit ae9e2a
	if (pb->progress_cb) {
Packit ae9e2a
		double current_time = git__timer();
Packit ae9e2a
		double elapsed = current_time - pb->last_progress_report_time;
Packit ae9e2a
Packit ae9e2a
		if (elapsed >= MIN_PROGRESS_UPDATE_INTERVAL) {
Packit ae9e2a
			pb->last_progress_report_time = current_time;
Packit ae9e2a
Packit ae9e2a
			ret = pb->progress_cb(
Packit ae9e2a
				GIT_PACKBUILDER_ADDING_OBJECTS,
Packit ae9e2a
				pb->nr_objects, 0, pb->progress_cb_payload);
Packit ae9e2a
Packit ae9e2a
			if (ret)
Packit ae9e2a
				return giterr_set_after_callback(ret);
Packit ae9e2a
		}
Packit ae9e2a
	}
Packit ae9e2a
Packit ae9e2a
	return 0;
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
static int get_delta(void **out, git_odb *odb, git_pobject *po)
Packit ae9e2a
{
Packit ae9e2a
	git_odb_object *src = NULL, *trg = NULL;
Packit ae9e2a
	size_t delta_size;
Packit ae9e2a
	void *delta_buf;
Packit ae9e2a
	int error;
Packit ae9e2a
Packit ae9e2a
	*out = NULL;
Packit ae9e2a
Packit ae9e2a
	if (git_odb_read(&src, odb, &po->delta->id) < 0 ||
Packit ae9e2a
	    git_odb_read(&trg, odb, &po->id) < 0)
Packit ae9e2a
		goto on_error;
Packit ae9e2a
Packit ae9e2a
	error = git_delta(&delta_buf, &delta_size,
Packit ae9e2a
		git_odb_object_data(src), git_odb_object_size(src),
Packit ae9e2a
		git_odb_object_data(trg), git_odb_object_size(trg),
Packit ae9e2a
		0);
Packit ae9e2a
Packit ae9e2a
	if (error < 0 && error != GIT_EBUFS)
Packit ae9e2a
		goto on_error;
Packit ae9e2a
Packit ae9e2a
	if (error == GIT_EBUFS || delta_size != po->delta_size) {
Packit ae9e2a
		giterr_set(GITERR_INVALID, "delta size changed");
Packit ae9e2a
		goto on_error;
Packit ae9e2a
	}
Packit ae9e2a
Packit ae9e2a
	*out = delta_buf;
Packit ae9e2a
Packit ae9e2a
	git_odb_object_free(src);
Packit ae9e2a
	git_odb_object_free(trg);
Packit ae9e2a
	return 0;
Packit ae9e2a
Packit ae9e2a
on_error:
Packit ae9e2a
	git_odb_object_free(src);
Packit ae9e2a
	git_odb_object_free(trg);
Packit ae9e2a
	return -1;
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
static int write_object(
Packit ae9e2a
	git_packbuilder *pb,
Packit ae9e2a
	git_pobject *po,
Packit ae9e2a
	int (*write_cb)(void *buf, size_t size, void *cb_data),
Packit ae9e2a
	void *cb_data)
Packit ae9e2a
{
Packit ae9e2a
	git_odb_object *obj = NULL;
Packit ae9e2a
	git_otype type;
Packit ae9e2a
	unsigned char hdr[10], *zbuf = NULL;
Packit ae9e2a
	void *data = NULL;
Packit ae9e2a
	size_t hdr_len, zbuf_len = COMPRESS_BUFLEN, data_len;
Packit ae9e2a
	int error;
Packit ae9e2a
Packit ae9e2a
	/*
Packit ae9e2a
	 * If we have a delta base, let's use the delta to save space.
Packit ae9e2a
	 * Otherwise load the whole object. 'data' ends up pointing to
Packit ae9e2a
	 * whatever data we want to put into the packfile.
Packit ae9e2a
	 */
Packit ae9e2a
	if (po->delta) {
Packit ae9e2a
		if (po->delta_data)
Packit ae9e2a
			data = po->delta_data;
Packit ae9e2a
		else if ((error = get_delta(&data, pb->odb, po)) < 0)
Packit ae9e2a
				goto done;
Packit ae9e2a
Packit ae9e2a
		data_len = po->delta_size;
Packit ae9e2a
		type = GIT_OBJ_REF_DELTA;
Packit ae9e2a
	} else {
Packit ae9e2a
		if ((error = git_odb_read(&obj, pb->odb, &po->id)) < 0)
Packit ae9e2a
			goto done;
Packit ae9e2a
Packit ae9e2a
		data = (void *)git_odb_object_data(obj);
Packit ae9e2a
		data_len = git_odb_object_size(obj);
Packit ae9e2a
		type = git_odb_object_type(obj);
Packit ae9e2a
	}
Packit ae9e2a
Packit ae9e2a
	/* Write header */
Packit ae9e2a
	hdr_len = git_packfile__object_header(hdr, data_len, type);
Packit ae9e2a
Packit ae9e2a
	if ((error = write_cb(hdr, hdr_len, cb_data)) < 0 ||
Packit ae9e2a
		(error = git_hash_update(&pb->ctx, hdr, hdr_len)) < 0)
Packit ae9e2a
		goto done;
Packit ae9e2a
Packit ae9e2a
	if (type == GIT_OBJ_REF_DELTA) {
Packit ae9e2a
		if ((error = write_cb(po->delta->id.id, GIT_OID_RAWSZ, cb_data)) < 0 ||
Packit ae9e2a
			(error = git_hash_update(&pb->ctx, po->delta->id.id, GIT_OID_RAWSZ)) < 0)
Packit ae9e2a
			goto done;
Packit ae9e2a
	}
Packit ae9e2a
Packit ae9e2a
	/* Write data */
Packit ae9e2a
	if (po->z_delta_size) {
Packit ae9e2a
		data_len = po->z_delta_size;
Packit ae9e2a
Packit ae9e2a
		if ((error = write_cb(data, data_len, cb_data)) < 0 ||
Packit ae9e2a
			(error = git_hash_update(&pb->ctx, data, data_len)) < 0)
Packit ae9e2a
			goto done;
Packit ae9e2a
	} else {
Packit ae9e2a
		zbuf = git__malloc(zbuf_len);
Packit ae9e2a
		GITERR_CHECK_ALLOC(zbuf);
Packit ae9e2a
Packit ae9e2a
		git_zstream_reset(&pb->zstream);
Packit ae9e2a
		git_zstream_set_input(&pb->zstream, data, data_len);
Packit ae9e2a
Packit ae9e2a
		while (!git_zstream_done(&pb->zstream)) {
Packit ae9e2a
			if ((error = git_zstream_get_output(zbuf, &zbuf_len, &pb->zstream)) < 0 ||
Packit ae9e2a
				(error = write_cb(zbuf, zbuf_len, cb_data)) < 0 ||
Packit ae9e2a
				(error = git_hash_update(&pb->ctx, zbuf, zbuf_len)) < 0)
Packit ae9e2a
				goto done;
Packit ae9e2a
Packit ae9e2a
			zbuf_len = COMPRESS_BUFLEN; /* reuse buffer */
Packit ae9e2a
		}
Packit ae9e2a
	}
Packit ae9e2a
Packit ae9e2a
	/*
Packit ae9e2a
	 * If po->delta is true, data is a delta and it is our
Packit ae9e2a
	 * responsibility to free it (otherwise it's a git_object's
Packit ae9e2a
	 * data). We set po->delta_data to NULL in case we got the
Packit ae9e2a
	 * data from there instead of get_delta(). If we didn't,
Packit ae9e2a
	 * there's no harm.
Packit ae9e2a
	 */
Packit ae9e2a
	if (po->delta) {
Packit ae9e2a
		git__free(data);
Packit ae9e2a
		po->delta_data = NULL;
Packit ae9e2a
	}
Packit ae9e2a
Packit ae9e2a
	pb->nr_written++;
Packit ae9e2a
Packit ae9e2a
done:
Packit ae9e2a
	git__free(zbuf);
Packit ae9e2a
	git_odb_object_free(obj);
Packit ae9e2a
	return error;
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
enum write_one_status {
Packit ae9e2a
	WRITE_ONE_SKIP = -1, /* already written */
Packit ae9e2a
	WRITE_ONE_BREAK = 0, /* writing this will bust the limit; not written */
Packit ae9e2a
	WRITE_ONE_WRITTEN = 1, /* normal */
Packit ae9e2a
	WRITE_ONE_RECURSIVE = 2 /* already scheduled to be written */
Packit ae9e2a
};
Packit ae9e2a
Packit ae9e2a
static int write_one(
Packit ae9e2a
	enum write_one_status *status,
Packit ae9e2a
	git_packbuilder *pb,
Packit ae9e2a
	git_pobject *po,
Packit ae9e2a
	int (*write_cb)(void *buf, size_t size, void *cb_data),
Packit ae9e2a
	void *cb_data)
Packit ae9e2a
{
Packit ae9e2a
	int error;
Packit ae9e2a
Packit ae9e2a
	if (po->recursing) {
Packit ae9e2a
		*status = WRITE_ONE_RECURSIVE;
Packit ae9e2a
		return 0;
Packit ae9e2a
	} else if (po->written) {
Packit ae9e2a
		*status = WRITE_ONE_SKIP;
Packit ae9e2a
		return 0;
Packit ae9e2a
	}
Packit ae9e2a
Packit ae9e2a
	if (po->delta) {
Packit ae9e2a
		po->recursing = 1;
Packit ae9e2a
Packit ae9e2a
		if ((error = write_one(status, pb, po->delta, write_cb, cb_data)) < 0)
Packit ae9e2a
			return error;
Packit ae9e2a
Packit ae9e2a
		/* we cannot depend on this one */
Packit ae9e2a
		if (*status == WRITE_ONE_RECURSIVE)
Packit ae9e2a
			po->delta = NULL;
Packit ae9e2a
	}
Packit ae9e2a
Packit ae9e2a
	*status = WRITE_ONE_WRITTEN;
Packit ae9e2a
	po->written = 1;
Packit ae9e2a
	po->recursing = 0;
Packit ae9e2a
Packit ae9e2a
	return write_object(pb, po, write_cb, cb_data);
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
GIT_INLINE(void) add_to_write_order(git_pobject **wo, size_t *endp,
Packit ae9e2a
	git_pobject *po)
Packit ae9e2a
{
Packit ae9e2a
	if (po->filled)
Packit ae9e2a
		return;
Packit ae9e2a
	wo[(*endp)++] = po;
Packit ae9e2a
	po->filled = 1;
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
static void add_descendants_to_write_order(git_pobject **wo, size_t *endp,
Packit ae9e2a
	git_pobject *po)
Packit ae9e2a
{
Packit ae9e2a
	int add_to_order = 1;
Packit ae9e2a
	while (po) {
Packit ae9e2a
		if (add_to_order) {
Packit ae9e2a
			git_pobject *s;
Packit ae9e2a
			/* add this node... */
Packit ae9e2a
			add_to_write_order(wo, endp, po);
Packit ae9e2a
			/* all its siblings... */
Packit ae9e2a
			for (s = po->delta_sibling; s; s = s->delta_sibling) {
Packit ae9e2a
				add_to_write_order(wo, endp, s);
Packit ae9e2a
			}
Packit ae9e2a
		}
Packit ae9e2a
		/* drop down a level to add left subtree nodes if possible */
Packit ae9e2a
		if (po->delta_child) {
Packit ae9e2a
			add_to_order = 1;
Packit ae9e2a
			po = po->delta_child;
Packit ae9e2a
		} else {
Packit ae9e2a
			add_to_order = 0;
Packit ae9e2a
			/* our sibling might have some children, it is next */
Packit ae9e2a
			if (po->delta_sibling) {
Packit ae9e2a
				po = po->delta_sibling;
Packit ae9e2a
				continue;
Packit ae9e2a
			}
Packit ae9e2a
			/* go back to our parent node */
Packit ae9e2a
			po = po->delta;
Packit ae9e2a
			while (po && !po->delta_sibling) {
Packit ae9e2a
				/* we're on the right side of a subtree, keep
Packit ae9e2a
				 * going up until we can go right again */
Packit ae9e2a
				po = po->delta;
Packit ae9e2a
			}
Packit ae9e2a
			if (!po) {
Packit ae9e2a
				/* done- we hit our original root node */
Packit ae9e2a
				return;
Packit ae9e2a
			}
Packit ae9e2a
			/* pass it off to sibling at this level */
Packit ae9e2a
			po = po->delta_sibling;
Packit ae9e2a
		}
Packit ae9e2a
	};
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
static void add_family_to_write_order(git_pobject **wo, size_t *endp,
Packit ae9e2a
	git_pobject *po)
Packit ae9e2a
{
Packit ae9e2a
	git_pobject *root;
Packit ae9e2a
Packit ae9e2a
	for (root = po; root->delta; root = root->delta)
Packit ae9e2a
		; /* nothing */
Packit ae9e2a
	add_descendants_to_write_order(wo, endp, root);
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
static int cb_tag_foreach(const char *name, git_oid *oid, void *data)
Packit ae9e2a
{
Packit ae9e2a
	git_packbuilder *pb = data;
Packit ae9e2a
	git_pobject *po;
Packit ae9e2a
	khiter_t pos;
Packit ae9e2a
Packit ae9e2a
	GIT_UNUSED(name);
Packit ae9e2a
Packit ae9e2a
	pos = git_oidmap_lookup_index(pb->object_ix, oid);
Packit ae9e2a
	if (!git_oidmap_valid_index(pb->object_ix, pos))
Packit ae9e2a
		return 0;
Packit ae9e2a
Packit ae9e2a
	po = git_oidmap_value_at(pb->object_ix, pos);
Packit ae9e2a
	po->tagged = 1;
Packit ae9e2a
Packit ae9e2a
	/* TODO: peel objects */
Packit ae9e2a
Packit ae9e2a
	return 0;
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
static git_pobject **compute_write_order(git_packbuilder *pb)
Packit ae9e2a
{
Packit ae9e2a
	size_t i, wo_end, last_untagged;
Packit ae9e2a
	git_pobject **wo;
Packit ae9e2a
Packit ae9e2a
	if ((wo = git__mallocarray(pb->nr_objects, sizeof(*wo))) == NULL)
Packit ae9e2a
		return NULL;
Packit ae9e2a
Packit ae9e2a
	for (i = 0; i < pb->nr_objects; i++) {
Packit ae9e2a
		git_pobject *po = pb->object_list + i;
Packit ae9e2a
		po->tagged = 0;
Packit ae9e2a
		po->filled = 0;
Packit ae9e2a
		po->delta_child = NULL;
Packit ae9e2a
		po->delta_sibling = NULL;
Packit ae9e2a
	}
Packit ae9e2a
Packit ae9e2a
	/*
Packit ae9e2a
	 * Fully connect delta_child/delta_sibling network.
Packit ae9e2a
	 * Make sure delta_sibling is sorted in the original
Packit ae9e2a
	 * recency order.
Packit ae9e2a
	 */
Packit ae9e2a
	for (i = pb->nr_objects; i > 0;) {
Packit ae9e2a
		git_pobject *po = &pb->object_list[--i];
Packit ae9e2a
		if (!po->delta)
Packit ae9e2a
			continue;
Packit ae9e2a
		/* Mark me as the first child */
Packit ae9e2a
		po->delta_sibling = po->delta->delta_child;
Packit ae9e2a
		po->delta->delta_child = po;
Packit ae9e2a
	}
Packit ae9e2a
Packit ae9e2a
	/*
Packit ae9e2a
	 * Mark objects that are at the tip of tags.
Packit ae9e2a
	 */
Packit ae9e2a
	if (git_tag_foreach(pb->repo, &cb_tag_foreach, pb) < 0) {
Packit ae9e2a
		git__free(wo);
Packit ae9e2a
		return NULL;
Packit ae9e2a
	}
Packit ae9e2a
Packit ae9e2a
	/*
Packit ae9e2a
	 * Give the objects in the original recency order until
Packit ae9e2a
	 * we see a tagged tip.
Packit ae9e2a
	 */
Packit ae9e2a
	for (i = wo_end = 0; i < pb->nr_objects; i++) {
Packit ae9e2a
		git_pobject *po = pb->object_list + i;
Packit ae9e2a
		if (po->tagged)
Packit ae9e2a
			break;
Packit ae9e2a
		add_to_write_order(wo, &wo_end, po);
Packit ae9e2a
	}
Packit ae9e2a
	last_untagged = i;
Packit ae9e2a
Packit ae9e2a
	/*
Packit ae9e2a
	 * Then fill all the tagged tips.
Packit ae9e2a
	 */
Packit ae9e2a
	for (; i < pb->nr_objects; i++) {
Packit ae9e2a
		git_pobject *po = pb->object_list + i;
Packit ae9e2a
		if (po->tagged)
Packit ae9e2a
			add_to_write_order(wo, &wo_end, po);
Packit ae9e2a
	}
Packit ae9e2a
Packit ae9e2a
	/*
Packit ae9e2a
	 * And then all remaining commits and tags.
Packit ae9e2a
	 */
Packit ae9e2a
	for (i = last_untagged; i < pb->nr_objects; i++) {
Packit ae9e2a
		git_pobject *po = pb->object_list + i;
Packit ae9e2a
		if (po->type != GIT_OBJ_COMMIT &&
Packit ae9e2a
		    po->type != GIT_OBJ_TAG)
Packit ae9e2a
			continue;
Packit ae9e2a
		add_to_write_order(wo, &wo_end, po);
Packit ae9e2a
	}
Packit ae9e2a
Packit ae9e2a
	/*
Packit ae9e2a
	 * And then all the trees.
Packit ae9e2a
	 */
Packit ae9e2a
	for (i = last_untagged; i < pb->nr_objects; i++) {
Packit ae9e2a
		git_pobject *po = pb->object_list + i;
Packit ae9e2a
		if (po->type != GIT_OBJ_TREE)
Packit ae9e2a
			continue;
Packit ae9e2a
		add_to_write_order(wo, &wo_end, po);
Packit ae9e2a
	}
Packit ae9e2a
Packit ae9e2a
	/*
Packit ae9e2a
	 * Finally all the rest in really tight order
Packit ae9e2a
	 */
Packit ae9e2a
	for (i = last_untagged; i < pb->nr_objects; i++) {
Packit ae9e2a
		git_pobject *po = pb->object_list + i;
Packit ae9e2a
		if (!po->filled)
Packit ae9e2a
			add_family_to_write_order(wo, &wo_end, po);
Packit ae9e2a
	}
Packit ae9e2a
Packit ae9e2a
	if (wo_end != pb->nr_objects) {
Packit ae9e2a
		git__free(wo);
Packit ae9e2a
		giterr_set(GITERR_INVALID, "invalid write order");
Packit ae9e2a
		return NULL;
Packit ae9e2a
	}
Packit ae9e2a
Packit ae9e2a
	return wo;
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
static int write_pack(git_packbuilder *pb,
Packit ae9e2a
	int (*write_cb)(void *buf, size_t size, void *cb_data),
Packit ae9e2a
	void *cb_data)
Packit ae9e2a
{
Packit ae9e2a
	git_pobject **write_order;
Packit ae9e2a
	git_pobject *po;
Packit ae9e2a
	enum write_one_status status;
Packit ae9e2a
	struct git_pack_header ph;
Packit ae9e2a
	git_oid entry_oid;
Packit ae9e2a
	size_t i = 0;
Packit ae9e2a
	int error = 0;
Packit ae9e2a
Packit ae9e2a
	write_order = compute_write_order(pb);
Packit ae9e2a
	if (write_order == NULL)
Packit ae9e2a
		return -1;
Packit ae9e2a
Packit ae9e2a
	if (!git__is_uint32(pb->nr_objects)) {
Packit ae9e2a
		giterr_set(GITERR_INVALID, "too many objects");
Packit ae9e2a
		return -1;
Packit ae9e2a
	}
Packit ae9e2a
Packit ae9e2a
	/* Write pack header */
Packit ae9e2a
	ph.hdr_signature = htonl(PACK_SIGNATURE);
Packit ae9e2a
	ph.hdr_version = htonl(PACK_VERSION);
Packit ae9e2a
	ph.hdr_entries = htonl(pb->nr_objects);
Packit ae9e2a
Packit ae9e2a
	if ((error = write_cb(&ph, sizeof(ph), cb_data)) < 0 ||
Packit ae9e2a
		(error = git_hash_update(&pb->ctx, &ph, sizeof(ph))) < 0)
Packit ae9e2a
		goto done;
Packit ae9e2a
Packit ae9e2a
	pb->nr_remaining = pb->nr_objects;
Packit ae9e2a
	do {
Packit ae9e2a
		pb->nr_written = 0;
Packit ae9e2a
		for ( ; i < pb->nr_objects; ++i) {
Packit ae9e2a
			po = write_order[i];
Packit ae9e2a
Packit ae9e2a
			if ((error = write_one(&status, pb, po, write_cb, cb_data)) < 0)
Packit ae9e2a
				goto done;
Packit ae9e2a
		}
Packit ae9e2a
Packit ae9e2a
		pb->nr_remaining -= pb->nr_written;
Packit ae9e2a
	} while (pb->nr_remaining && i < pb->nr_objects);
Packit ae9e2a
Packit ae9e2a
	if ((error = git_hash_final(&entry_oid, &pb->ctx)) < 0)
Packit ae9e2a
		goto done;
Packit ae9e2a
Packit ae9e2a
	error = write_cb(entry_oid.id, GIT_OID_RAWSZ, cb_data);
Packit ae9e2a
Packit ae9e2a
done:
Packit ae9e2a
	/* if callback cancelled writing, we must still free delta_data */
Packit ae9e2a
	for ( ; i < pb->nr_objects; ++i) {
Packit ae9e2a
		po = write_order[i];
Packit ae9e2a
		if (po->delta_data) {
Packit ae9e2a
			git__free(po->delta_data);
Packit ae9e2a
			po->delta_data = NULL;
Packit ae9e2a
		}
Packit ae9e2a
	}
Packit ae9e2a
Packit ae9e2a
	git__free(write_order);
Packit ae9e2a
	return error;
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
static int write_pack_buf(void *buf, size_t size, void *data)
Packit ae9e2a
{
Packit ae9e2a
	git_buf *b = (git_buf *)data;
Packit ae9e2a
	return git_buf_put(b, buf, size);
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
static int type_size_sort(const void *_a, const void *_b)
Packit ae9e2a
{
Packit ae9e2a
	const git_pobject *a = (git_pobject *)_a;
Packit ae9e2a
	const git_pobject *b = (git_pobject *)_b;
Packit ae9e2a
Packit ae9e2a
	if (a->type > b->type)
Packit ae9e2a
		return -1;
Packit ae9e2a
	if (a->type < b->type)
Packit ae9e2a
		return 1;
Packit ae9e2a
	if (a->hash > b->hash)
Packit ae9e2a
		return -1;
Packit ae9e2a
	if (a->hash < b->hash)
Packit ae9e2a
		return 1;
Packit ae9e2a
	/*
Packit ae9e2a
	 * TODO
Packit ae9e2a
	 *
Packit ae9e2a
	if (a->preferred_base > b->preferred_base)
Packit ae9e2a
		return -1;
Packit ae9e2a
	if (a->preferred_base < b->preferred_base)
Packit ae9e2a
		return 1;
Packit ae9e2a
	*/
Packit ae9e2a
	if (a->size > b->size)
Packit ae9e2a
		return -1;
Packit ae9e2a
	if (a->size < b->size)
Packit ae9e2a
		return 1;
Packit ae9e2a
	return a < b ? -1 : (a > b); /* newest first */
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
static int delta_cacheable(
Packit ae9e2a
	git_packbuilder *pb,
Packit ae9e2a
	size_t src_size,
Packit ae9e2a
	size_t trg_size,
Packit ae9e2a
	size_t delta_size)
Packit ae9e2a
{
Packit ae9e2a
	size_t new_size;
Packit ae9e2a
Packit ae9e2a
	if (git__add_sizet_overflow(&new_size, pb->delta_cache_size, delta_size))
Packit ae9e2a
		return 0;
Packit ae9e2a
Packit ae9e2a
	if (pb->max_delta_cache_size && new_size > pb->max_delta_cache_size)
Packit ae9e2a
		return 0;
Packit ae9e2a
Packit ae9e2a
	if (delta_size < pb->cache_max_small_delta_size)
Packit ae9e2a
		return 1;
Packit ae9e2a
Packit ae9e2a
	/* cache delta, if objects are large enough compared to delta size */
Packit ae9e2a
	if ((src_size >> 20) + (trg_size >> 21) > (delta_size >> 10))
Packit ae9e2a
		return 1;
Packit ae9e2a
Packit ae9e2a
	return 0;
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
static int try_delta(git_packbuilder *pb, struct unpacked *trg,
Packit ae9e2a
		     struct unpacked *src, size_t max_depth,
Packit ae9e2a
			 size_t *mem_usage, int *ret)
Packit ae9e2a
{
Packit ae9e2a
	git_pobject *trg_object = trg->object;
Packit ae9e2a
	git_pobject *src_object = src->object;
Packit ae9e2a
	git_odb_object *obj;
Packit ae9e2a
	size_t trg_size, src_size, delta_size, sizediff, max_size, sz;
Packit ae9e2a
	size_t ref_depth;
Packit ae9e2a
	void *delta_buf;
Packit ae9e2a
Packit ae9e2a
	/* Don't bother doing diffs between different types */
Packit ae9e2a
	if (trg_object->type != src_object->type) {
Packit ae9e2a
		*ret = -1;
Packit ae9e2a
		return 0;
Packit ae9e2a
	}
Packit ae9e2a
Packit ae9e2a
	*ret = 0;
Packit ae9e2a
Packit ae9e2a
	/* TODO: support reuse-delta */
Packit ae9e2a
Packit ae9e2a
	/* Let's not bust the allowed depth. */
Packit ae9e2a
	if (src->depth >= max_depth)
Packit ae9e2a
		return 0;
Packit ae9e2a
Packit ae9e2a
	/* Now some size filtering heuristics. */
Packit ae9e2a
	trg_size = trg_object->size;
Packit ae9e2a
	if (!trg_object->delta) {
Packit ae9e2a
		max_size = trg_size/2 - 20;
Packit ae9e2a
		ref_depth = 1;
Packit ae9e2a
	} else {
Packit ae9e2a
		max_size = trg_object->delta_size;
Packit ae9e2a
		ref_depth = trg->depth;
Packit ae9e2a
	}
Packit ae9e2a
Packit ae9e2a
	max_size = (uint64_t)max_size * (max_depth - src->depth) /
Packit ae9e2a
					(max_depth - ref_depth + 1);
Packit ae9e2a
	if (max_size == 0)
Packit ae9e2a
		return 0;
Packit ae9e2a
Packit ae9e2a
	src_size = src_object->size;
Packit ae9e2a
	sizediff = src_size < trg_size ? trg_size - src_size : 0;
Packit ae9e2a
	if (sizediff >= max_size)
Packit ae9e2a
		return 0;
Packit ae9e2a
	if (trg_size < src_size / 32)
Packit ae9e2a
		return 0;
Packit ae9e2a
Packit ae9e2a
	/* Load data if not already done */
Packit ae9e2a
	if (!trg->data) {
Packit ae9e2a
		if (git_odb_read(&obj, pb->odb, &trg_object->id) < 0)
Packit ae9e2a
			return -1;
Packit ae9e2a
Packit ae9e2a
		sz = git_odb_object_size(obj);
Packit ae9e2a
		trg->data = git__malloc(sz);
Packit ae9e2a
		GITERR_CHECK_ALLOC(trg->data);
Packit ae9e2a
		memcpy(trg->data, git_odb_object_data(obj), sz);
Packit ae9e2a
Packit ae9e2a
		git_odb_object_free(obj);
Packit ae9e2a
Packit ae9e2a
		if (sz != trg_size) {
Packit ae9e2a
			giterr_set(GITERR_INVALID,
Packit ae9e2a
				   "inconsistent target object length");
Packit ae9e2a
			return -1;
Packit ae9e2a
		}
Packit ae9e2a
Packit ae9e2a
		*mem_usage += sz;
Packit ae9e2a
	}
Packit ae9e2a
	if (!src->data) {
Packit ae9e2a
		size_t obj_sz;
Packit ae9e2a
Packit ae9e2a
		if (git_odb_read(&obj, pb->odb, &src_object->id) < 0 ||
Packit ae9e2a
			!git__is_ulong(obj_sz = git_odb_object_size(obj)))
Packit ae9e2a
			return -1;
Packit ae9e2a
Packit ae9e2a
		sz = obj_sz;
Packit ae9e2a
		src->data = git__malloc(sz);
Packit ae9e2a
		GITERR_CHECK_ALLOC(src->data);
Packit ae9e2a
		memcpy(src->data, git_odb_object_data(obj), sz);
Packit ae9e2a
Packit ae9e2a
		git_odb_object_free(obj);
Packit ae9e2a
Packit ae9e2a
		if (sz != src_size) {
Packit ae9e2a
			giterr_set(GITERR_INVALID,
Packit ae9e2a
				   "inconsistent source object length");
Packit ae9e2a
			return -1;
Packit ae9e2a
		}
Packit ae9e2a
Packit ae9e2a
		*mem_usage += sz;
Packit ae9e2a
	}
Packit ae9e2a
	if (!src->index) {
Packit ae9e2a
		if (git_delta_index_init(&src->index, src->data, src_size) < 0)
Packit ae9e2a
			return 0; /* suboptimal pack - out of memory */
Packit ae9e2a
Packit ae9e2a
		*mem_usage += git_delta_index_size(src->index);
Packit ae9e2a
	}
Packit ae9e2a
Packit ae9e2a
	if (git_delta_create_from_index(&delta_buf, &delta_size, src->index, trg->data, trg_size,
Packit ae9e2a
		max_size) < 0)
Packit ae9e2a
		return 0;
Packit ae9e2a
Packit ae9e2a
	if (trg_object->delta) {
Packit ae9e2a
		/* Prefer only shallower same-sized deltas. */
Packit ae9e2a
		if (delta_size == trg_object->delta_size &&
Packit ae9e2a
		    src->depth + 1 >= trg->depth) {
Packit ae9e2a
			git__free(delta_buf);
Packit ae9e2a
			return 0;
Packit ae9e2a
		}
Packit ae9e2a
	}
Packit ae9e2a
Packit ae9e2a
	git_packbuilder__cache_lock(pb);
Packit ae9e2a
	if (trg_object->delta_data) {
Packit ae9e2a
		git__free(trg_object->delta_data);
Packit ae9e2a
		assert(pb->delta_cache_size >= trg_object->delta_size);
Packit ae9e2a
		pb->delta_cache_size -= trg_object->delta_size;
Packit ae9e2a
		trg_object->delta_data = NULL;
Packit ae9e2a
	}
Packit ae9e2a
	if (delta_cacheable(pb, src_size, trg_size, delta_size)) {
Packit ae9e2a
		bool overflow = git__add_sizet_overflow(
Packit ae9e2a
			&pb->delta_cache_size, pb->delta_cache_size, delta_size);
Packit ae9e2a
Packit ae9e2a
		git_packbuilder__cache_unlock(pb);
Packit ae9e2a
Packit ae9e2a
		if (overflow) {
Packit ae9e2a
			git__free(delta_buf);
Packit ae9e2a
			return -1;
Packit ae9e2a
		}
Packit ae9e2a
Packit ae9e2a
		trg_object->delta_data = git__realloc(delta_buf, delta_size);
Packit ae9e2a
		GITERR_CHECK_ALLOC(trg_object->delta_data);
Packit ae9e2a
	} else {
Packit ae9e2a
		/* create delta when writing the pack */
Packit ae9e2a
		git_packbuilder__cache_unlock(pb);
Packit ae9e2a
		git__free(delta_buf);
Packit ae9e2a
	}
Packit ae9e2a
Packit ae9e2a
	trg_object->delta = src_object;
Packit ae9e2a
	trg_object->delta_size = delta_size;
Packit ae9e2a
	trg->depth = src->depth + 1;
Packit ae9e2a
Packit ae9e2a
	*ret = 1;
Packit ae9e2a
	return 0;
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
static size_t check_delta_limit(git_pobject *me, size_t n)
Packit ae9e2a
{
Packit ae9e2a
	git_pobject *child = me->delta_child;
Packit ae9e2a
	size_t m = n;
Packit ae9e2a
Packit ae9e2a
	while (child) {
Packit ae9e2a
		size_t c = check_delta_limit(child, n + 1);
Packit ae9e2a
		if (m < c)
Packit ae9e2a
			m = c;
Packit ae9e2a
		child = child->delta_sibling;
Packit ae9e2a
	}
Packit ae9e2a
	return m;
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
static size_t free_unpacked(struct unpacked *n)
Packit ae9e2a
{
Packit ae9e2a
	size_t freed_mem = 0;
Packit ae9e2a
Packit ae9e2a
	if (n->index) {
Packit ae9e2a
		freed_mem += git_delta_index_size(n->index);
Packit ae9e2a
		git_delta_index_free(n->index);
Packit ae9e2a
	}
Packit ae9e2a
	n->index = NULL;
Packit ae9e2a
Packit ae9e2a
	if (n->data) {
Packit ae9e2a
		freed_mem += n->object->size;
Packit ae9e2a
		git__free(n->data);
Packit ae9e2a
		n->data = NULL;
Packit ae9e2a
	}
Packit ae9e2a
	n->object = NULL;
Packit ae9e2a
	n->depth = 0;
Packit ae9e2a
	return freed_mem;
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
static int report_delta_progress(
Packit ae9e2a
	git_packbuilder *pb, uint32_t count, bool force)
Packit ae9e2a
{
Packit ae9e2a
	int ret;
Packit ae9e2a
Packit ae9e2a
	if (pb->progress_cb) {
Packit ae9e2a
		double current_time = git__timer();
Packit ae9e2a
		double elapsed = current_time - pb->last_progress_report_time;
Packit ae9e2a
Packit ae9e2a
		if (force || elapsed >= MIN_PROGRESS_UPDATE_INTERVAL) {
Packit ae9e2a
			pb->last_progress_report_time = current_time;
Packit ae9e2a
Packit ae9e2a
			ret = pb->progress_cb(
Packit ae9e2a
				GIT_PACKBUILDER_DELTAFICATION,
Packit ae9e2a
				count, pb->nr_objects, pb->progress_cb_payload);
Packit ae9e2a
Packit ae9e2a
			if (ret)
Packit ae9e2a
				return giterr_set_after_callback(ret);
Packit ae9e2a
		}
Packit ae9e2a
	}
Packit ae9e2a
Packit ae9e2a
	return 0;
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
static int find_deltas(git_packbuilder *pb, git_pobject **list,
Packit ae9e2a
	size_t *list_size, size_t window, size_t depth)
Packit ae9e2a
{
Packit ae9e2a
	git_pobject *po;
Packit ae9e2a
	git_buf zbuf = GIT_BUF_INIT;
Packit ae9e2a
	struct unpacked *array;
Packit ae9e2a
	size_t idx = 0, count = 0;
Packit ae9e2a
	size_t mem_usage = 0;
Packit ae9e2a
	size_t i;
Packit ae9e2a
	int error = -1;
Packit ae9e2a
Packit ae9e2a
	array = git__calloc(window, sizeof(struct unpacked));
Packit ae9e2a
	GITERR_CHECK_ALLOC(array);
Packit ae9e2a
Packit ae9e2a
	for (;;) {
Packit ae9e2a
		struct unpacked *n = array + idx;
Packit ae9e2a
		size_t max_depth, j, best_base = SIZE_MAX;
Packit ae9e2a
Packit ae9e2a
		git_packbuilder__progress_lock(pb);
Packit ae9e2a
		if (!*list_size) {
Packit ae9e2a
			git_packbuilder__progress_unlock(pb);
Packit ae9e2a
			break;
Packit ae9e2a
		}
Packit ae9e2a
Packit ae9e2a
		pb->nr_deltified += 1;
Packit ae9e2a
		report_delta_progress(pb, pb->nr_deltified, false);
Packit ae9e2a
Packit ae9e2a
		po = *list++;
Packit ae9e2a
		(*list_size)--;
Packit ae9e2a
		git_packbuilder__progress_unlock(pb);
Packit ae9e2a
Packit ae9e2a
		mem_usage -= free_unpacked(n);
Packit ae9e2a
		n->object = po;
Packit ae9e2a
Packit ae9e2a
		while (pb->window_memory_limit &&
Packit ae9e2a
		       mem_usage > pb->window_memory_limit &&
Packit ae9e2a
		       count > 1) {
Packit ae9e2a
			size_t tail = (idx + window - count) % window;
Packit ae9e2a
			mem_usage -= free_unpacked(array + tail);
Packit ae9e2a
			count--;
Packit ae9e2a
		}
Packit ae9e2a
Packit ae9e2a
		/*
Packit ae9e2a
		 * If the current object is at pack edge, take the depth the
Packit ae9e2a
		 * objects that depend on the current object into account
Packit ae9e2a
		 * otherwise they would become too deep.
Packit ae9e2a
		 */
Packit ae9e2a
		max_depth = depth;
Packit ae9e2a
		if (po->delta_child) {
Packit ae9e2a
			size_t delta_limit = check_delta_limit(po, 0);
Packit ae9e2a
Packit ae9e2a
			if (delta_limit > max_depth)
Packit ae9e2a
				goto next;
Packit ae9e2a
Packit ae9e2a
			max_depth -= delta_limit;
Packit ae9e2a
		}
Packit ae9e2a
Packit ae9e2a
		j = window;
Packit ae9e2a
		while (--j > 0) {
Packit ae9e2a
			int ret;
Packit ae9e2a
			size_t other_idx = idx + j;
Packit ae9e2a
			struct unpacked *m;
Packit ae9e2a
Packit ae9e2a
			if (other_idx >= window)
Packit ae9e2a
				other_idx -= window;
Packit ae9e2a
Packit ae9e2a
			m = array + other_idx;
Packit ae9e2a
			if (!m->object)
Packit ae9e2a
				break;
Packit ae9e2a
Packit ae9e2a
			if (try_delta(pb, n, m, max_depth, &mem_usage, &ret) < 0)
Packit ae9e2a
				goto on_error;
Packit ae9e2a
			if (ret < 0)
Packit ae9e2a
				break;
Packit ae9e2a
			else if (ret > 0)
Packit ae9e2a
				best_base = other_idx;
Packit ae9e2a
		}
Packit ae9e2a
Packit ae9e2a
		/*
Packit ae9e2a
		 * If we decided to cache the delta data, then it is best
Packit ae9e2a
		 * to compress it right away.  First because we have to do
Packit ae9e2a
		 * it anyway, and doing it here while we're threaded will
Packit ae9e2a
		 * save a lot of time in the non threaded write phase,
Packit ae9e2a
		 * as well as allow for caching more deltas within
Packit ae9e2a
		 * the same cache size limit.
Packit ae9e2a
		 * ...
Packit ae9e2a
		 * But only if not writing to stdout, since in that case
Packit ae9e2a
		 * the network is most likely throttling writes anyway,
Packit ae9e2a
		 * and therefore it is best to go to the write phase ASAP
Packit ae9e2a
		 * instead, as we can afford spending more time compressing
Packit ae9e2a
		 * between writes at that moment.
Packit ae9e2a
		 */
Packit ae9e2a
		if (po->delta_data) {
Packit ae9e2a
			if (git_zstream_deflatebuf(&zbuf, po->delta_data, po->delta_size) < 0)
Packit ae9e2a
				goto on_error;
Packit ae9e2a
Packit ae9e2a
			git__free(po->delta_data);
Packit ae9e2a
			po->delta_data = git__malloc(zbuf.size);
Packit ae9e2a
			GITERR_CHECK_ALLOC(po->delta_data);
Packit ae9e2a
Packit ae9e2a
			memcpy(po->delta_data, zbuf.ptr, zbuf.size);
Packit ae9e2a
			po->z_delta_size = zbuf.size;
Packit ae9e2a
			git_buf_clear(&zbuf);
Packit ae9e2a
Packit ae9e2a
			git_packbuilder__cache_lock(pb);
Packit ae9e2a
			pb->delta_cache_size -= po->delta_size;
Packit ae9e2a
			pb->delta_cache_size += po->z_delta_size;
Packit ae9e2a
			git_packbuilder__cache_unlock(pb);
Packit ae9e2a
		}
Packit ae9e2a
Packit ae9e2a
		/*
Packit ae9e2a
		 * If we made n a delta, and if n is already at max
Packit ae9e2a
		 * depth, leaving it in the window is pointless.  we
Packit ae9e2a
		 * should evict it first.
Packit ae9e2a
		 */
Packit ae9e2a
		if (po->delta && max_depth <= n->depth)
Packit ae9e2a
			continue;
Packit ae9e2a
Packit ae9e2a
		/*
Packit ae9e2a
		 * Move the best delta base up in the window, after the
Packit ae9e2a
		 * currently deltified object, to keep it longer.  It will
Packit ae9e2a
		 * be the first base object to be attempted next.
Packit ae9e2a
		 */
Packit ae9e2a
		if (po->delta) {
Packit ae9e2a
			struct unpacked swap = array[best_base];
Packit ae9e2a
			size_t dist = (window + idx - best_base) % window;
Packit ae9e2a
			size_t dst = best_base;
Packit ae9e2a
			while (dist--) {
Packit ae9e2a
				size_t src = (dst + 1) % window;
Packit ae9e2a
				array[dst] = array[src];
Packit ae9e2a
				dst = src;
Packit ae9e2a
			}
Packit ae9e2a
			array[dst] = swap;
Packit ae9e2a
		}
Packit ae9e2a
Packit ae9e2a
		next:
Packit ae9e2a
		idx++;
Packit ae9e2a
		if (count + 1 < window)
Packit ae9e2a
			count++;
Packit ae9e2a
		if (idx >= window)
Packit ae9e2a
			idx = 0;
Packit ae9e2a
	}
Packit ae9e2a
	error = 0;
Packit ae9e2a
Packit ae9e2a
on_error:
Packit ae9e2a
	for (i = 0; i < window; ++i) {
Packit ae9e2a
		git__free(array[i].index);
Packit ae9e2a
		git__free(array[i].data);
Packit ae9e2a
	}
Packit ae9e2a
	git__free(array);
Packit ae9e2a
	git_buf_free(&zbuf);
Packit ae9e2a
Packit ae9e2a
	return error;
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
#ifdef GIT_THREADS
Packit ae9e2a
Packit ae9e2a
struct thread_params {
Packit ae9e2a
	git_thread thread;
Packit ae9e2a
	git_packbuilder *pb;
Packit ae9e2a
Packit ae9e2a
	git_pobject **list;
Packit ae9e2a
Packit ae9e2a
	git_cond cond;
Packit ae9e2a
	git_mutex mutex;
Packit ae9e2a
Packit ae9e2a
	size_t list_size;
Packit ae9e2a
	size_t remaining;
Packit ae9e2a
Packit ae9e2a
	size_t window;
Packit ae9e2a
	size_t depth;
Packit ae9e2a
	size_t working;
Packit ae9e2a
	size_t data_ready;
Packit ae9e2a
};
Packit ae9e2a
Packit ae9e2a
static void *threaded_find_deltas(void *arg)
Packit ae9e2a
{
Packit ae9e2a
	struct thread_params *me = arg;
Packit ae9e2a
Packit ae9e2a
	while (me->remaining) {
Packit ae9e2a
		if (find_deltas(me->pb, me->list, &me->remaining,
Packit ae9e2a
				me->window, me->depth) < 0) {
Packit ae9e2a
			; /* TODO */
Packit ae9e2a
		}
Packit ae9e2a
Packit ae9e2a
		git_packbuilder__progress_lock(me->pb);
Packit ae9e2a
		me->working = 0;
Packit ae9e2a
		git_cond_signal(&me->pb->progress_cond);
Packit ae9e2a
		git_packbuilder__progress_unlock(me->pb);
Packit ae9e2a
Packit ae9e2a
		if (git_mutex_lock(&me->mutex)) {
Packit ae9e2a
			giterr_set(GITERR_THREAD, "unable to lock packfile condition mutex");
Packit ae9e2a
			return NULL;
Packit ae9e2a
		}
Packit ae9e2a
Packit ae9e2a
		while (!me->data_ready)
Packit ae9e2a
			git_cond_wait(&me->cond, &me->mutex);
Packit ae9e2a
Packit ae9e2a
		/*
Packit ae9e2a
		 * We must not set ->data_ready before we wait on the
Packit ae9e2a
		 * condition because the main thread may have set it to 1
Packit ae9e2a
		 * before we get here. In order to be sure that new
Packit ae9e2a
		 * work is available if we see 1 in ->data_ready, it
Packit ae9e2a
		 * was initialized to 0 before this thread was spawned
Packit ae9e2a
		 * and we reset it to 0 right away.
Packit ae9e2a
		 */
Packit ae9e2a
		me->data_ready = 0;
Packit ae9e2a
		git_mutex_unlock(&me->mutex);
Packit ae9e2a
	}
Packit ae9e2a
	/* leave ->working 1 so that this doesn't get more work assigned */
Packit ae9e2a
	return NULL;
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
static int ll_find_deltas(git_packbuilder *pb, git_pobject **list,
Packit ae9e2a
			  size_t list_size, size_t window, size_t depth)
Packit ae9e2a
{
Packit ae9e2a
	struct thread_params *p;
Packit ae9e2a
	size_t i;
Packit ae9e2a
	int ret, active_threads = 0;
Packit ae9e2a
Packit ae9e2a
	if (!pb->nr_threads)
Packit ae9e2a
		pb->nr_threads = git_online_cpus();
Packit ae9e2a
Packit ae9e2a
	if (pb->nr_threads <= 1) {
Packit ae9e2a
		find_deltas(pb, list, &list_size, window, depth);
Packit ae9e2a
		return 0;
Packit ae9e2a
	}
Packit ae9e2a
Packit ae9e2a
	p = git__mallocarray(pb->nr_threads, sizeof(*p));
Packit ae9e2a
	GITERR_CHECK_ALLOC(p);
Packit ae9e2a
Packit ae9e2a
	/* Partition the work among the threads */
Packit ae9e2a
	for (i = 0; i < pb->nr_threads; ++i) {
Packit ae9e2a
		size_t sub_size = list_size / (pb->nr_threads - i);
Packit ae9e2a
Packit ae9e2a
		/* don't use too small segments or no deltas will be found */
Packit ae9e2a
		if (sub_size < 2*window && i+1 < pb->nr_threads)
Packit ae9e2a
			sub_size = 0;
Packit ae9e2a
Packit ae9e2a
		p[i].pb = pb;
Packit ae9e2a
		p[i].window = window;
Packit ae9e2a
		p[i].depth = depth;
Packit ae9e2a
		p[i].working = 1;
Packit ae9e2a
		p[i].data_ready = 0;
Packit ae9e2a
Packit ae9e2a
		/* try to split chunks on "path" boundaries */
Packit ae9e2a
		while (sub_size && sub_size < list_size &&
Packit ae9e2a
		       list[sub_size]->hash &&
Packit ae9e2a
		       list[sub_size]->hash == list[sub_size-1]->hash)
Packit ae9e2a
			sub_size++;
Packit ae9e2a
Packit ae9e2a
		p[i].list = list;
Packit ae9e2a
		p[i].list_size = sub_size;
Packit ae9e2a
		p[i].remaining = sub_size;
Packit ae9e2a
Packit ae9e2a
		list += sub_size;
Packit ae9e2a
		list_size -= sub_size;
Packit ae9e2a
	}
Packit ae9e2a
Packit ae9e2a
	/* Start work threads */
Packit ae9e2a
	for (i = 0; i < pb->nr_threads; ++i) {
Packit ae9e2a
		if (!p[i].list_size)
Packit ae9e2a
			continue;
Packit ae9e2a
Packit ae9e2a
		git_mutex_init(&p[i].mutex);
Packit ae9e2a
		git_cond_init(&p[i].cond);
Packit ae9e2a
Packit ae9e2a
		ret = git_thread_create(&p[i].thread,
Packit ae9e2a
					threaded_find_deltas, &p[i]);
Packit ae9e2a
		if (ret) {
Packit ae9e2a
			giterr_set(GITERR_THREAD, "unable to create thread");
Packit ae9e2a
			return -1;
Packit ae9e2a
		}
Packit ae9e2a
		active_threads++;
Packit ae9e2a
	}
Packit ae9e2a
Packit ae9e2a
	/*
Packit ae9e2a
	 * Now let's wait for work completion.  Each time a thread is done
Packit ae9e2a
	 * with its work, we steal half of the remaining work from the
Packit ae9e2a
	 * thread with the largest number of unprocessed objects and give
Packit ae9e2a
	 * it to that newly idle thread.  This ensure good load balancing
Packit ae9e2a
	 * until the remaining object list segments are simply too short
Packit ae9e2a
	 * to be worth splitting anymore.
Packit ae9e2a
	 */
Packit ae9e2a
	while (active_threads) {
Packit ae9e2a
		struct thread_params *target = NULL;
Packit ae9e2a
		struct thread_params *victim = NULL;
Packit ae9e2a
		size_t sub_size = 0;
Packit ae9e2a
Packit ae9e2a
		/* Start by locating a thread that has transitioned its
Packit ae9e2a
		 * 'working' flag from 1 -> 0. This indicates that it is
Packit ae9e2a
		 * ready to receive more work using our work-stealing
Packit ae9e2a
		 * algorithm. */
Packit ae9e2a
		git_packbuilder__progress_lock(pb);
Packit ae9e2a
		for (;;) {
Packit ae9e2a
			for (i = 0; !target && i < pb->nr_threads; i++)
Packit ae9e2a
				if (!p[i].working)
Packit ae9e2a
					target = &p[i];
Packit ae9e2a
			if (target)
Packit ae9e2a
				break;
Packit ae9e2a
			git_cond_wait(&pb->progress_cond, &pb->progress_mutex);
Packit ae9e2a
		}
Packit ae9e2a
Packit ae9e2a
		/* At this point we hold the progress lock and have located
Packit ae9e2a
		 * a thread to receive more work. We still need to locate a
Packit ae9e2a
		 * thread from which to steal work (the victim). */
Packit ae9e2a
		for (i = 0; i < pb->nr_threads; i++)
Packit ae9e2a
			if (p[i].remaining > 2*window &&
Packit ae9e2a
			    (!victim || victim->remaining < p[i].remaining))
Packit ae9e2a
				victim = &p[i];
Packit ae9e2a
Packit ae9e2a
		if (victim) {
Packit ae9e2a
			sub_size = victim->remaining / 2;
Packit ae9e2a
			list = victim->list + victim->list_size - sub_size;
Packit ae9e2a
			while (sub_size && list[0]->hash &&
Packit ae9e2a
			       list[0]->hash == list[-1]->hash) {
Packit ae9e2a
				list++;
Packit ae9e2a
				sub_size--;
Packit ae9e2a
			}
Packit ae9e2a
			if (!sub_size) {
Packit ae9e2a
				/*
Packit ae9e2a
				 * It is possible for some "paths" to have
Packit ae9e2a
				 * so many objects that no hash boundary
Packit ae9e2a
				 * might be found.  Let's just steal the
Packit ae9e2a
				 * exact half in that case.
Packit ae9e2a
				 */
Packit ae9e2a
				sub_size = victim->remaining / 2;
Packit ae9e2a
				list -= sub_size;
Packit ae9e2a
			}
Packit ae9e2a
			target->list = list;
Packit ae9e2a
			victim->list_size -= sub_size;
Packit ae9e2a
			victim->remaining -= sub_size;
Packit ae9e2a
		}
Packit ae9e2a
		target->list_size = sub_size;
Packit ae9e2a
		target->remaining = sub_size;
Packit ae9e2a
		target->working = 1;
Packit ae9e2a
		git_packbuilder__progress_unlock(pb);
Packit ae9e2a
Packit ae9e2a
		if (git_mutex_lock(&target->mutex)) {
Packit ae9e2a
			giterr_set(GITERR_THREAD, "unable to lock packfile condition mutex");
Packit ae9e2a
			git__free(p);
Packit ae9e2a
			return -1;
Packit ae9e2a
		}
Packit ae9e2a
Packit ae9e2a
		target->data_ready = 1;
Packit ae9e2a
		git_cond_signal(&target->cond);
Packit ae9e2a
		git_mutex_unlock(&target->mutex);
Packit ae9e2a
Packit ae9e2a
		if (!sub_size) {
Packit ae9e2a
			git_thread_join(&target->thread, NULL);
Packit ae9e2a
			git_cond_free(&target->cond);
Packit ae9e2a
			git_mutex_free(&target->mutex);
Packit ae9e2a
			active_threads--;
Packit ae9e2a
		}
Packit ae9e2a
	}
Packit ae9e2a
Packit ae9e2a
	git__free(p);
Packit ae9e2a
	return 0;
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
#else
Packit ae9e2a
#define ll_find_deltas(pb, l, ls, w, d) find_deltas(pb, l, &ls, w, d)
Packit ae9e2a
#endif
Packit ae9e2a
Packit ae9e2a
static int prepare_pack(git_packbuilder *pb)
Packit ae9e2a
{
Packit ae9e2a
	git_pobject **delta_list;
Packit ae9e2a
	size_t i, n = 0;
Packit ae9e2a
Packit ae9e2a
	if (pb->nr_objects == 0 || pb->done)
Packit ae9e2a
		return 0; /* nothing to do */
Packit ae9e2a
Packit ae9e2a
	/*
Packit ae9e2a
	 * Although we do not report progress during deltafication, we
Packit ae9e2a
	 * at least report that we are in the deltafication stage
Packit ae9e2a
	 */
Packit ae9e2a
	if (pb->progress_cb)
Packit ae9e2a
			pb->progress_cb(GIT_PACKBUILDER_DELTAFICATION, 0, pb->nr_objects, pb->progress_cb_payload);
Packit ae9e2a
Packit ae9e2a
	delta_list = git__mallocarray(pb->nr_objects, sizeof(*delta_list));
Packit ae9e2a
	GITERR_CHECK_ALLOC(delta_list);
Packit ae9e2a
Packit ae9e2a
	for (i = 0; i < pb->nr_objects; ++i) {
Packit ae9e2a
		git_pobject *po = pb->object_list + i;
Packit ae9e2a
Packit ae9e2a
		/* Make sure the item is within our size limits */
Packit ae9e2a
		if (po->size < 50 || po->size > pb->big_file_threshold)
Packit ae9e2a
			continue;
Packit ae9e2a
Packit ae9e2a
		delta_list[n++] = po;
Packit ae9e2a
	}
Packit ae9e2a
Packit ae9e2a
	if (n > 1) {
Packit ae9e2a
		git__tsort((void **)delta_list, n, type_size_sort);
Packit ae9e2a
		if (ll_find_deltas(pb, delta_list, n,
Packit ae9e2a
				   GIT_PACK_WINDOW + 1,
Packit ae9e2a
				   GIT_PACK_DEPTH) < 0) {
Packit ae9e2a
			git__free(delta_list);
Packit ae9e2a
			return -1;
Packit ae9e2a
		}
Packit ae9e2a
	}
Packit ae9e2a
Packit ae9e2a
	report_delta_progress(pb, pb->nr_objects, true);
Packit ae9e2a
Packit ae9e2a
	pb->done = true;
Packit ae9e2a
	git__free(delta_list);
Packit ae9e2a
	return 0;
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
#define PREPARE_PACK if (prepare_pack(pb) < 0) { return -1; }
Packit ae9e2a
Packit ae9e2a
int git_packbuilder_foreach(git_packbuilder *pb, int (*cb)(void *buf, size_t size, void *payload), void *payload)
Packit ae9e2a
{
Packit ae9e2a
	PREPARE_PACK;
Packit ae9e2a
	return write_pack(pb, cb, payload);
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
int git_packbuilder_write_buf(git_buf *buf, git_packbuilder *pb)
Packit ae9e2a
{
Packit ae9e2a
	PREPARE_PACK;
Packit ae9e2a
	git_buf_sanitize(buf);
Packit ae9e2a
	return write_pack(pb, &write_pack_buf, buf);
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
static int write_cb(void *buf, size_t len, void *payload)
Packit ae9e2a
{
Packit ae9e2a
	struct pack_write_context *ctx = payload;
Packit ae9e2a
	return git_indexer_append(ctx->indexer, buf, len, ctx->stats);
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
int git_packbuilder_write(
Packit ae9e2a
	git_packbuilder *pb,
Packit ae9e2a
	const char *path,
Packit ae9e2a
	unsigned int mode,
Packit ae9e2a
	git_transfer_progress_cb progress_cb,
Packit ae9e2a
	void *progress_cb_payload)
Packit ae9e2a
{
Packit ae9e2a
	git_indexer *indexer;
Packit ae9e2a
	git_transfer_progress stats;
Packit ae9e2a
	struct pack_write_context ctx;
Packit ae9e2a
	int t;
Packit ae9e2a
Packit ae9e2a
	PREPARE_PACK;
Packit ae9e2a
Packit ae9e2a
	if (git_indexer_new(
Packit ae9e2a
		&indexer, path, mode, pb->odb, progress_cb, progress_cb_payload) < 0)
Packit ae9e2a
		return -1;
Packit ae9e2a
Packit ae9e2a
	if (!git_repository__cvar(&t, pb->repo, GIT_CVAR_FSYNCOBJECTFILES) && t)
Packit ae9e2a
		git_indexer__set_fsync(indexer, 1);
Packit ae9e2a
Packit ae9e2a
	ctx.indexer = indexer;
Packit ae9e2a
	ctx.stats = &stat;;
Packit ae9e2a
Packit ae9e2a
	if (git_packbuilder_foreach(pb, write_cb, &ctx) < 0 ||
Packit ae9e2a
		git_indexer_commit(indexer, &stats) < 0) {
Packit ae9e2a
		git_indexer_free(indexer);
Packit ae9e2a
		return -1;
Packit ae9e2a
	}
Packit ae9e2a
Packit ae9e2a
	git_oid_cpy(&pb->pack_oid, git_indexer_hash(indexer));
Packit ae9e2a
Packit ae9e2a
	git_indexer_free(indexer);
Packit ae9e2a
	return 0;
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
#undef PREPARE_PACK
Packit ae9e2a
Packit ae9e2a
const git_oid *git_packbuilder_hash(git_packbuilder *pb)
Packit ae9e2a
{
Packit ae9e2a
	return &pb->pack_oid;
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
Packit ae9e2a
static int cb_tree_walk(
Packit ae9e2a
	const char *root, const git_tree_entry *entry, void *payload)
Packit ae9e2a
{
Packit ae9e2a
	int error;
Packit ae9e2a
	struct tree_walk_context *ctx = payload;
Packit ae9e2a
Packit ae9e2a
	/* A commit inside a tree represents a submodule commit and should be skipped. */
Packit ae9e2a
	if (git_tree_entry_type(entry) == GIT_OBJ_COMMIT)
Packit ae9e2a
		return 0;
Packit ae9e2a
Packit ae9e2a
	if (!(error = git_buf_sets(&ctx->buf, root)) &&
Packit ae9e2a
		!(error = git_buf_puts(&ctx->buf, git_tree_entry_name(entry))))
Packit ae9e2a
		error = git_packbuilder_insert(
Packit ae9e2a
			ctx->pb, git_tree_entry_id(entry), git_buf_cstr(&ctx->buf));
Packit ae9e2a
Packit ae9e2a
	return error;
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
int git_packbuilder_insert_commit(git_packbuilder *pb, const git_oid *oid)
Packit ae9e2a
{
Packit ae9e2a
	git_commit *commit;
Packit ae9e2a
Packit ae9e2a
	if (git_commit_lookup(&commit, pb->repo, oid) < 0 ||
Packit ae9e2a
		git_packbuilder_insert(pb, oid, NULL) < 0)
Packit ae9e2a
		return -1;
Packit ae9e2a
Packit ae9e2a
	if (git_packbuilder_insert_tree(pb, git_commit_tree_id(commit)) < 0)
Packit ae9e2a
		return -1;
Packit ae9e2a
Packit ae9e2a
	git_commit_free(commit);
Packit ae9e2a
	return 0;
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
int git_packbuilder_insert_tree(git_packbuilder *pb, const git_oid *oid)
Packit ae9e2a
{
Packit ae9e2a
	int error;
Packit ae9e2a
	git_tree *tree = NULL;
Packit ae9e2a
	struct tree_walk_context context = { pb, GIT_BUF_INIT };
Packit ae9e2a
Packit ae9e2a
	if (!(error = git_tree_lookup(&tree, pb->repo, oid)) &&
Packit ae9e2a
	    !(error = git_packbuilder_insert(pb, oid, NULL)))
Packit ae9e2a
		error = git_tree_walk(tree, GIT_TREEWALK_PRE, cb_tree_walk, &context);
Packit ae9e2a
Packit ae9e2a
	git_tree_free(tree);
Packit ae9e2a
	git_buf_free(&context.buf);
Packit ae9e2a
	return error;
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
int git_packbuilder_insert_recur(git_packbuilder *pb, const git_oid *id, const char *name)
Packit ae9e2a
{
Packit ae9e2a
	git_object *obj;
Packit ae9e2a
	int error;
Packit ae9e2a
Packit ae9e2a
	assert(pb && id);
Packit ae9e2a
Packit ae9e2a
	if ((error = git_object_lookup(&obj, pb->repo, id, GIT_OBJ_ANY)) < 0)
Packit ae9e2a
		return error;
Packit ae9e2a
Packit ae9e2a
	switch (git_object_type(obj)) {
Packit ae9e2a
	case GIT_OBJ_BLOB:
Packit ae9e2a
		error = git_packbuilder_insert(pb, id, name);
Packit ae9e2a
		break;
Packit ae9e2a
	case GIT_OBJ_TREE:
Packit ae9e2a
		error = git_packbuilder_insert_tree(pb, id);
Packit ae9e2a
		break;
Packit ae9e2a
	case GIT_OBJ_COMMIT:
Packit ae9e2a
		error = git_packbuilder_insert_commit(pb, id);
Packit ae9e2a
		break;
Packit ae9e2a
	case GIT_OBJ_TAG:
Packit ae9e2a
		if ((error = git_packbuilder_insert(pb, id, name)) < 0)
Packit ae9e2a
			goto cleanup;
Packit ae9e2a
		error = git_packbuilder_insert_recur(pb, git_tag_target_id((git_tag *) obj), NULL);
Packit ae9e2a
		break;
Packit ae9e2a
Packit ae9e2a
	default:
Packit ae9e2a
		giterr_set(GITERR_INVALID, "unknown object type");
Packit ae9e2a
		error = -1;
Packit ae9e2a
	}
Packit ae9e2a
Packit ae9e2a
cleanup:
Packit ae9e2a
	git_object_free(obj);
Packit ae9e2a
	return error;
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
size_t git_packbuilder_object_count(git_packbuilder *pb)
Packit ae9e2a
{
Packit ae9e2a
	return pb->nr_objects;
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
size_t git_packbuilder_written(git_packbuilder *pb)
Packit ae9e2a
{
Packit ae9e2a
	return pb->nr_written;
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
int lookup_walk_object(git_walk_object **out, git_packbuilder *pb, const git_oid *id)
Packit ae9e2a
{
Packit ae9e2a
	git_walk_object *obj;
Packit ae9e2a
Packit ae9e2a
	obj = git_pool_mallocz(&pb->object_pool, 1);
Packit ae9e2a
	if (!obj) {
Packit ae9e2a
		giterr_set_oom();
Packit ae9e2a
		return -1;
Packit ae9e2a
	}
Packit ae9e2a
Packit ae9e2a
	git_oid_cpy(&obj->id, id);
Packit ae9e2a
Packit ae9e2a
	*out = obj;
Packit ae9e2a
	return 0;
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
static int retrieve_object(git_walk_object **out, git_packbuilder *pb, const git_oid *id)
Packit ae9e2a
{
Packit ae9e2a
	int error;
Packit ae9e2a
	khiter_t pos;
Packit ae9e2a
	git_walk_object *obj;
Packit ae9e2a
Packit ae9e2a
	pos = git_oidmap_lookup_index(pb->walk_objects, id);
Packit ae9e2a
	if (git_oidmap_valid_index(pb->walk_objects, pos)) {
Packit ae9e2a
		obj = git_oidmap_value_at(pb->walk_objects, pos);
Packit ae9e2a
	} else {
Packit ae9e2a
		if ((error = lookup_walk_object(&obj, pb, id)) < 0)
Packit ae9e2a
			return error;
Packit ae9e2a
Packit ae9e2a
		git_oidmap_insert(pb->walk_objects, &obj->id, obj, &error);
Packit ae9e2a
	}
Packit ae9e2a
Packit ae9e2a
	*out = obj;
Packit ae9e2a
	return 0;
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
static int mark_blob_uninteresting(git_packbuilder *pb, const git_oid *id)
Packit ae9e2a
{
Packit ae9e2a
	int error;
Packit ae9e2a
	git_walk_object *obj;
Packit ae9e2a
Packit ae9e2a
	if ((error = retrieve_object(&obj, pb, id)) < 0)
Packit ae9e2a
		return error;
Packit ae9e2a
Packit ae9e2a
	obj->uninteresting = 1;
Packit ae9e2a
Packit ae9e2a
	return 0;
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
static int mark_tree_uninteresting(git_packbuilder *pb, const git_oid *id)
Packit ae9e2a
{
Packit ae9e2a
	git_walk_object *obj;
Packit ae9e2a
	git_tree *tree;
Packit ae9e2a
	int error;
Packit ae9e2a
	size_t i;
Packit ae9e2a
Packit ae9e2a
	if ((error = retrieve_object(&obj, pb, id)) < 0)
Packit ae9e2a
		return error;
Packit ae9e2a
Packit ae9e2a
	if (obj->uninteresting)
Packit ae9e2a
		return 0;
Packit ae9e2a
Packit ae9e2a
	obj->uninteresting = 1;
Packit ae9e2a
Packit ae9e2a
	if ((error = git_tree_lookup(&tree, pb->repo, id)) < 0)
Packit ae9e2a
		return error;
Packit ae9e2a
Packit ae9e2a
	for (i = 0; i < git_tree_entrycount(tree); i++) {
Packit ae9e2a
		const git_tree_entry *entry = git_tree_entry_byindex(tree, i);
Packit ae9e2a
		const git_oid *entry_id = git_tree_entry_id(entry);
Packit ae9e2a
		switch (git_tree_entry_type(entry)) {
Packit ae9e2a
		case GIT_OBJ_TREE:
Packit ae9e2a
			if ((error = mark_tree_uninteresting(pb, entry_id)) < 0)
Packit ae9e2a
				goto cleanup;
Packit ae9e2a
			break;
Packit ae9e2a
		case GIT_OBJ_BLOB:
Packit ae9e2a
			if ((error = mark_blob_uninteresting(pb, entry_id)) < 0)
Packit ae9e2a
				goto cleanup;
Packit ae9e2a
			break;
Packit ae9e2a
		default:
Packit ae9e2a
			/* it's a submodule or something unknown, we don't want it */
Packit ae9e2a
			;
Packit ae9e2a
		}
Packit ae9e2a
	}
Packit ae9e2a
Packit ae9e2a
cleanup:
Packit ae9e2a
	git_tree_free(tree);
Packit ae9e2a
	return error;
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
/*
Packit ae9e2a
 * Mark the edges of the graph uninteresting. Since we start from a
Packit ae9e2a
 * git_revwalk, the commits are already uninteresting, but we need to
Packit ae9e2a
 * mark the trees and blobs.
Packit ae9e2a
 */
Packit ae9e2a
static int mark_edges_uninteresting(git_packbuilder *pb, git_commit_list *commits)
Packit ae9e2a
{
Packit ae9e2a
	int error;
Packit ae9e2a
	git_commit_list *list;
Packit ae9e2a
	git_commit *commit;
Packit ae9e2a
Packit ae9e2a
	for (list = commits; list; list = list->next) {
Packit ae9e2a
		if (!list->item->uninteresting)
Packit ae9e2a
			continue;
Packit ae9e2a
Packit ae9e2a
		if ((error = git_commit_lookup(&commit, pb->repo, &list->item->oid)) < 0)
Packit ae9e2a
			return error;
Packit ae9e2a
Packit ae9e2a
		error = mark_tree_uninteresting(pb, git_commit_tree_id(commit));
Packit ae9e2a
		git_commit_free(commit);
Packit ae9e2a
Packit ae9e2a
		if (error < 0)
Packit ae9e2a
			return error;
Packit ae9e2a
	}
Packit ae9e2a
Packit ae9e2a
	return 0;
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
int insert_tree(git_packbuilder *pb, git_tree *tree)
Packit ae9e2a
{
Packit ae9e2a
	size_t i;
Packit ae9e2a
	int error;
Packit ae9e2a
	git_tree *subtree;
Packit ae9e2a
	git_walk_object *obj;
Packit ae9e2a
	const char *name;
Packit ae9e2a
Packit ae9e2a
	if ((error = retrieve_object(&obj, pb, git_tree_id(tree))) < 0)
Packit ae9e2a
		return error;
Packit ae9e2a
Packit ae9e2a
	if (obj->seen)
Packit ae9e2a
		return 0;
Packit ae9e2a
Packit ae9e2a
	obj->seen = 1;
Packit ae9e2a
Packit ae9e2a
	if ((error = git_packbuilder_insert(pb, &obj->id, NULL)))
Packit ae9e2a
		return error;
Packit ae9e2a
Packit ae9e2a
	for (i = 0; i < git_tree_entrycount(tree); i++) {
Packit ae9e2a
		const git_tree_entry *entry = git_tree_entry_byindex(tree, i);
Packit ae9e2a
		const git_oid *entry_id = git_tree_entry_id(entry);
Packit ae9e2a
		switch (git_tree_entry_type(entry)) {
Packit ae9e2a
		case GIT_OBJ_TREE:
Packit ae9e2a
			if ((error = git_tree_lookup(&subtree, pb->repo, entry_id)) < 0)
Packit ae9e2a
				return error;
Packit ae9e2a
Packit ae9e2a
			error = insert_tree(pb, subtree);
Packit ae9e2a
			git_tree_free(subtree);
Packit ae9e2a
Packit ae9e2a
			if (error < 0)
Packit ae9e2a
				return error;
Packit ae9e2a
Packit ae9e2a
			break;
Packit ae9e2a
		case GIT_OBJ_BLOB:
Packit ae9e2a
			name = git_tree_entry_name(entry);
Packit ae9e2a
			if ((error = git_packbuilder_insert(pb, entry_id, name)) < 0)
Packit ae9e2a
				return error;
Packit ae9e2a
			break;
Packit ae9e2a
		default:
Packit ae9e2a
			/* it's a submodule or something unknown, we don't want it */
Packit ae9e2a
			;
Packit ae9e2a
		}
Packit ae9e2a
	}
Packit ae9e2a
Packit ae9e2a
Packit ae9e2a
	return error;
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
int insert_commit(git_packbuilder *pb, git_walk_object *obj)
Packit ae9e2a
{
Packit ae9e2a
	int error;
Packit ae9e2a
	git_commit *commit = NULL;
Packit ae9e2a
	git_tree *tree = NULL;
Packit ae9e2a
Packit ae9e2a
	obj->seen = 1;
Packit ae9e2a
Packit ae9e2a
	if ((error = git_packbuilder_insert(pb, &obj->id, NULL)) < 0)
Packit ae9e2a
		return error;
Packit ae9e2a
Packit ae9e2a
	if ((error = git_commit_lookup(&commit, pb->repo, &obj->id)) < 0)
Packit ae9e2a
		return error;
Packit ae9e2a
Packit ae9e2a
	if ((error = git_tree_lookup(&tree, pb->repo, git_commit_tree_id(commit))) < 0)
Packit ae9e2a
		goto cleanup;
Packit ae9e2a
Packit ae9e2a
	if ((error = insert_tree(pb, tree)) < 0)
Packit ae9e2a
		goto cleanup;
Packit ae9e2a
Packit ae9e2a
cleanup:
Packit ae9e2a
	git_commit_free(commit);
Packit ae9e2a
	git_tree_free(tree);
Packit ae9e2a
	return error;
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
int git_packbuilder_insert_walk(git_packbuilder *pb, git_revwalk *walk)
Packit ae9e2a
{
Packit ae9e2a
	int error;
Packit ae9e2a
	git_oid id;
Packit ae9e2a
	git_walk_object *obj;
Packit ae9e2a
Packit ae9e2a
	assert(pb && walk);
Packit ae9e2a
Packit ae9e2a
	if ((error = mark_edges_uninteresting(pb, walk->user_input)) < 0)
Packit ae9e2a
		return error;
Packit ae9e2a
Packit ae9e2a
	/*
Packit ae9e2a
	 * TODO: git marks the parents of the edges
Packit ae9e2a
	 * uninteresting. This may provide a speed advantage, but does
Packit ae9e2a
	 * seem to assume the remote does not have a single-commit
Packit ae9e2a
	 * history on the other end.
Packit ae9e2a
	 */
Packit ae9e2a
Packit ae9e2a
	/* walk down each tree up to the blobs and insert them, stopping when uninteresting */
Packit ae9e2a
	while ((error = git_revwalk_next(&id, walk)) == 0) {
Packit ae9e2a
		if ((error = retrieve_object(&obj, pb, &id)) < 0)
Packit ae9e2a
			return error;
Packit ae9e2a
Packit ae9e2a
		if (obj->seen || obj->uninteresting)
Packit ae9e2a
			continue;
Packit ae9e2a
Packit ae9e2a
		if ((error = insert_commit(pb, obj)) < 0)
Packit ae9e2a
			return error;
Packit ae9e2a
	}
Packit ae9e2a
Packit ae9e2a
	if (error == GIT_ITEROVER)
Packit ae9e2a
		error = 0;
Packit ae9e2a
Packit ae9e2a
	return error;
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
int git_packbuilder_set_callbacks(git_packbuilder *pb, git_packbuilder_progress progress_cb, void *progress_cb_payload)
Packit ae9e2a
{
Packit ae9e2a
	if (!pb)
Packit ae9e2a
		return -1;
Packit ae9e2a
Packit ae9e2a
	pb->progress_cb = progress_cb;
Packit ae9e2a
	pb->progress_cb_payload = progress_cb_payload;
Packit ae9e2a
Packit ae9e2a
	return 0;
Packit ae9e2a
}
Packit ae9e2a
Packit ae9e2a
void git_packbuilder_free(git_packbuilder *pb)
Packit ae9e2a
{
Packit ae9e2a
	if (pb == NULL)
Packit ae9e2a
		return;
Packit ae9e2a
Packit ae9e2a
#ifdef GIT_THREADS
Packit ae9e2a
Packit ae9e2a
	git_mutex_free(&pb->cache_mutex);
Packit ae9e2a
	git_mutex_free(&pb->progress_mutex);
Packit ae9e2a
	git_cond_free(&pb->progress_cond);
Packit ae9e2a
Packit ae9e2a
#endif
Packit ae9e2a
Packit ae9e2a
	if (pb->odb)
Packit ae9e2a
		git_odb_free(pb->odb);
Packit ae9e2a
Packit ae9e2a
	if (pb->object_ix)
Packit ae9e2a
		git_oidmap_free(pb->object_ix);
Packit ae9e2a
Packit ae9e2a
	if (pb->object_list)
Packit ae9e2a
		git__free(pb->object_list);
Packit ae9e2a
Packit ae9e2a
	git_oidmap_free(pb->walk_objects);
Packit ae9e2a
	git_pool_clear(&pb->object_pool);
Packit ae9e2a
Packit ae9e2a
	git_hash_ctx_cleanup(&pb->ctx);
Packit ae9e2a
	git_zstream_free(&pb->zstream);
Packit ae9e2a
Packit ae9e2a
	git__free(pb);
Packit ae9e2a
}