[thirdparty/git.git] / upload-pack.c

#include "cache.h"
#include "refs.h"
#include "pkt-line.h"
#include "sideband.h"
#include "tag.h"
#include "object.h"
#include "commit.h"
#include "exec_cmd.h"
#include "diff.h"
#include "revision.h"
#include "list-objects.h"
#include "run-command.h"

static const char upload_pack_usage[] = "git-upload-pack [--strict] [--timeout=nn] <dir>";

/* bits #0..7 in revision.h, #8..10 in commit.c */
#define THEY_HAVE	(1u << 11)
#define OUR_REF		(1u << 12)
#define WANTED		(1u << 13)
#define COMMON_KNOWN	(1u << 14)
#define REACHABLE	(1u << 15)

#define SHALLOW		(1u << 16)
#define NOT_SHALLOW	(1u << 17)
#define CLIENT_SHALLOW	(1u << 18)

static unsigned long oldest_have;

static int multi_ack, nr_our_refs;
static int use_thin_pack, use_ofs_delta, no_progress;
static struct object_array have_obj;
static struct object_array want_obj;
static unsigned int timeout;
/* 0 for no sideband,
 * otherwise maximum packet size (up to 65520 bytes).
 */
static int use_sideband;
static int debug_fd;

static void reset_timeout(void)
{
	alarm(timeout);
}

static int strip(char *line, int len)
{
	if (len && line[len-1] == '\n')
		line[--len] = 0;
	return len;
}

static ssize_t send_client_data(int fd, const char *data, ssize_t sz)
{
	if (use_sideband)
		return send_sideband(1, fd, data, sz, use_sideband);
	if (fd == 3)
		/* emergency quit */
		fd = 2;
	if (fd == 2) {
		/* XXX: are we happy to lose stuff here? */
		xwrite(fd, data, sz);
		return sz;
	}
	return safe_write(fd, data, sz);
}

static FILE *pack_pipe = NULL;
static void show_commit(struct commit *commit)
{
	if (commit->object.flags & BOUNDARY)
		fputc('-', pack_pipe);
	if (fputs(sha1_to_hex(commit->object.sha1), pack_pipe) < 0)
		die("broken output pipe");
	fputc('\n', pack_pipe);
	fflush(pack_pipe);
	free(commit->buffer);
	commit->buffer = NULL;
}

static void show_object(struct object_array_entry *p)
{
	/* An object with name "foo\n0000000..." can be used to
	 * confuse downstream git-pack-objects very badly.
	 */
	const char *ep = strchr(p->name, '\n');
	if (ep) {
		fprintf(pack_pipe, "%s %.*s\n", sha1_to_hex(p->item->sha1),
		       (int) (ep - p->name),
		       p->name);
	}
	else
		fprintf(pack_pipe, "%s %s\n",
				sha1_to_hex(p->item->sha1), p->name);
}

static void show_edge(struct commit *commit)
{
	fprintf(pack_pipe, "-%s\n", sha1_to_hex(commit->object.sha1));
}

static int do_rev_list(int fd, void *create_full_pack)
{
	int i;
	struct rev_info revs;

	pack_pipe = fdopen(fd, "w");
	if (create_full_pack)
		use_thin_pack = 0; /* no point doing it */
	init_revisions(&revs, NULL);
	revs.tag_objects = 1;
	revs.tree_objects = 1;
	revs.blob_objects = 1;
	if (use_thin_pack)
		revs.edge_hint = 1;

	if (create_full_pack) {
		const char *args[] = {"rev-list", "--all", NULL};
		setup_revisions(2, args, &revs, NULL);
	} else {
		for (i = 0; i < want_obj.nr; i++) {
			struct object *o = want_obj.objects[i].item;
			/* why??? */
			o->flags &= ~UNINTERESTING;
			add_pending_object(&revs, o, NULL);
		}
		for (i = 0; i < have_obj.nr; i++) {
			struct object *o = have_obj.objects[i].item;
			o->flags |= UNINTERESTING;
			add_pending_object(&revs, o, NULL);
		}
		setup_revisions(0, NULL, &revs, NULL);
	}
	if (prepare_revision_walk(&revs))
		die("revision walk setup failed");
	mark_edges_uninteresting(revs.commits, &revs, show_edge);
	traverse_commit_list(&revs, show_commit, show_object);
	return 0;
}

static void create_pack_file(void)
{
	struct async rev_list;
	struct child_process pack_objects;
	int create_full_pack = (nr_our_refs == want_obj.nr && !have_obj.nr);
	char data[8193], progress[128];
	char abort_msg[] = "aborting due to possible repository "
		"corruption on the remote side.";
	int buffered = -1;
	ssize_t sz;
	const char *argv[10];
	int arg = 0;

	rev_list.proc = do_rev_list;
	/* .data is just a boolean: any non-NULL value will do */
	rev_list.data = create_full_pack ? &rev_list : NULL;
	if (start_async(&rev_list))
		die("git-upload-pack: unable to fork git-rev-list");

	argv[arg++] = "pack-objects";
	argv[arg++] = "--stdout";
	if (!no_progress)
		argv[arg++] = "--progress";
	if (use_ofs_delta)
		argv[arg++] = "--delta-base-offset";
	argv[arg++] = NULL;

	memset(&pack_objects, 0, sizeof(pack_objects));
	pack_objects.in = rev_list.out;	/* start_command closes it */
	pack_objects.out = -1;
	pack_objects.err = -1;
	pack_objects.git_cmd = 1;
	pack_objects.argv = argv;

	if (start_command(&pack_objects))
		die("git-upload-pack: unable to fork git-pack-objects");

	/* We read from pack_objects.err to capture stderr output for
	 * progress bar, and pack_objects.out to capture the pack data.
	 */

	while (1) {
		struct pollfd pfd[2];
		int pe, pu, pollsize;

		reset_timeout();

		pollsize = 0;
		pe = pu = -1;

		if (0 <= pack_objects.out) {
			pfd[pollsize].fd = pack_objects.out;
			pfd[pollsize].events = POLLIN;
			pu = pollsize;
			pollsize++;
		}
		if (0 <= pack_objects.err) {
			pfd[pollsize].fd = pack_objects.err;
			pfd[pollsize].events = POLLIN;
			pe = pollsize;
			pollsize++;
		}

		if (!pollsize)
			break;

		if (poll(pfd, pollsize, -1) < 0) {
			if (errno != EINTR) {
				error("poll failed, resuming: %s",
				      strerror(errno));
				sleep(1);
			}
			continue;
		}
		if (0 <= pu && (pfd[pu].revents & (POLLIN|POLLHUP))) {
			/* Data ready; we keep the last byte to ourselves
			 * in case we detect broken rev-list, so that we
			 * can leave the stream corrupted.  This is
			 * unfortunate -- unpack-objects would happily
			 * accept a valid packdata with trailing garbage,
			 * so appending garbage after we pass all the
			 * pack data is not good enough to signal
			 * breakage to downstream.
			 */
			char *cp = data;
			ssize_t outsz = 0;
			if (0 <= buffered) {
				*cp++ = buffered;
				outsz++;
			}
			sz = xread(pack_objects.out, cp,
				  sizeof(data) - outsz);
			if (0 < sz)
					;
			else if (sz == 0) {
				close(pack_objects.out);
				pack_objects.out = -1;
			}
			else
				goto fail;
			sz += outsz;
			if (1 < sz) {
				buffered = data[sz-1] & 0xFF;
				sz--;
			}
			else
				buffered = -1;
			sz = send_client_data(1, data, sz);
			if (sz < 0)
				goto fail;
		}
		if (0 <= pe && (pfd[pe].revents & (POLLIN|POLLHUP))) {
			/* Status ready; we ship that in the side-band
			 * or dump to the standard error.
			 */
			sz = xread(pack_objects.err, progress,
				  sizeof(progress));
			if (0 < sz)
				send_client_data(2, progress, sz);
			else if (sz == 0) {
				close(pack_objects.err);
				pack_objects.err = -1;
			}
			else
				goto fail;
		}
	}

	if (finish_command(&pack_objects)) {
		error("git-upload-pack: git-pack-objects died with error.");
		goto fail;
	}
	if (finish_async(&rev_list))
		goto fail;	/* error was already reported */

	/* flush the data */
	if (0 <= buffered) {
		data[0] = buffered;
		sz = send_client_data(1, data, 1);
		if (sz < 0)
			goto fail;
		fprintf(stderr, "flushed.\n");
	}
	if (use_sideband)
		packet_flush(1);
	return;

 fail:
	send_client_data(3, abort_msg, sizeof(abort_msg));
	die("git-upload-pack: %s", abort_msg);
}

static int got_sha1(char *hex, unsigned char *sha1)
{
	struct object *o;
	int we_knew_they_have = 0;

	if (get_sha1_hex(hex, sha1))
		die("git-upload-pack: expected SHA1 object, got '%s'", hex);
	if (!has_sha1_file(sha1))
		return -1;

	o = lookup_object(sha1);
	if (!(o && o->parsed))
		o = parse_object(sha1);
	if (!o)
		die("oops (%s)", sha1_to_hex(sha1));
	if (o->type == OBJ_COMMIT) {
		struct commit_list *parents;
		struct commit *commit = (struct commit *)o;
		if (o->flags & THEY_HAVE)
			we_knew_they_have = 1;
		else
			o->flags |= THEY_HAVE;
		if (!oldest_have || (commit->date < oldest_have))
			oldest_have = commit->date;
		for (parents = commit->parents;
		     parents;
		     parents = parents->next)
			parents->item->object.flags |= THEY_HAVE;
	}
	if (!we_knew_they_have) {
		add_object_array(o, NULL, &have_obj);
		return 1;
	}
	return 0;
}

static int reachable(struct commit *want)
{
	struct commit_list *work = NULL;

	insert_by_date(want, &work);
	while (work) {
		struct commit_list *list = work->next;
		struct commit *commit = work->item;
		free(work);
		work = list;

		if (commit->object.flags & THEY_HAVE) {
			want->object.flags |= COMMON_KNOWN;
			break;
		}
		if (!commit->object.parsed)
			parse_object(commit->object.sha1);
		if (commit->object.flags & REACHABLE)
			continue;
		commit->object.flags |= REACHABLE;
		if (commit->date < oldest_have)
			continue;
		for (list = commit->parents; list; list = list->next) {
			struct commit *parent = list->item;
			if (!(parent->object.flags & REACHABLE))
				insert_by_date(parent, &work);
		}
	}
	want->object.flags |= REACHABLE;
	clear_commit_marks(want, REACHABLE);
	free_commit_list(work);
	return (want->object.flags & COMMON_KNOWN);
}

static int ok_to_give_up(void)
{
	int i;

	if (!have_obj.nr)
		return 0;

	for (i = 0; i < want_obj.nr; i++) {
		struct object *want = want_obj.objects[i].item;

		if (want->flags & COMMON_KNOWN)
			continue;
		want = deref_tag(want, "a want line", 0);
		if (!want || want->type != OBJ_COMMIT) {
			/* no way to tell if this is reachable by
			 * looking at the ancestry chain alone, so
			 * leave a note to ourselves not to worry about
			 * this object anymore.
			 */
			want_obj.objects[i].item->flags |= COMMON_KNOWN;
			continue;
		}
		if (!reachable((struct commit *)want))
			return 0;
	}
	return 1;
}

static int get_common_commits(void)
{
	static char line[1000];
	unsigned char sha1[20];
	char hex[41], last_hex[41];
	int len;

	save_commit_buffer = 0;

	for(;;) {
		len = packet_read_line(0, line, sizeof(line));
		reset_timeout();

		if (!len) {
			if (have_obj.nr == 0 || multi_ack)
				packet_write(1, "NAK\n");
			continue;
		}
		len = strip(line, len);
		if (!prefixcmp(line, "have ")) {
			switch (got_sha1(line+5, sha1)) {
			case -1: /* they have what we do not */
				if (multi_ack && ok_to_give_up())
					packet_write(1, "ACK %s continue\n",
						     sha1_to_hex(sha1));
				break;
			default:
				memcpy(hex, sha1_to_hex(sha1), 41);
				if (multi_ack) {
					const char *msg = "ACK %s continue\n";
					packet_write(1, msg, hex);
					memcpy(last_hex, hex, 41);
				}
				else if (have_obj.nr == 1)
					packet_write(1, "ACK %s\n", hex);
				break;
			}
			continue;
		}
		if (!strcmp(line, "done")) {
			if (have_obj.nr > 0) {
				if (multi_ack)
					packet_write(1, "ACK %s\n", last_hex);
				return 0;
			}
			packet_write(1, "NAK\n");
			return -1;
		}
		die("git-upload-pack: expected SHA1 list, got '%s'", line);
	}
}

static void receive_needs(void)
{
	struct object_array shallows = {0, 0, NULL};
	static char line[1000];
	int len, depth = 0;

	if (debug_fd)
		write_in_full(debug_fd, "#S\n", 3);
	for (;;) {
		struct object *o;
		unsigned char sha1_buf[20];
		len = packet_read_line(0, line, sizeof(line));
		reset_timeout();
		if (!len)
			break;
		if (debug_fd)
			write_in_full(debug_fd, line, len);

		if (!prefixcmp(line, "shallow ")) {
			unsigned char sha1[20];
			struct object *object;
			use_thin_pack = 0;
			if (get_sha1(line + 8, sha1))
				die("invalid shallow line: %s", line);
			object = parse_object(sha1);
			if (!object)
				die("did not find object for %s", line);
			object->flags |= CLIENT_SHALLOW;
			add_object_array(object, NULL, &shallows);
			continue;
		}
		if (!prefixcmp(line, "deepen ")) {
			char *end;
			use_thin_pack = 0;
			depth = strtol(line + 7, &end, 0);
			if (end == line + 7 || depth <= 0)
				die("Invalid deepen: %s", line);
			continue;
		}
		if (prefixcmp(line, "want ") ||
		    get_sha1_hex(line+5, sha1_buf))
			die("git-upload-pack: protocol error, "
			    "expected to get sha, not '%s'", line);
		if (strstr(line+45, "multi_ack"))
			multi_ack = 1;
		if (strstr(line+45, "thin-pack"))
			use_thin_pack = 1;
		if (strstr(line+45, "ofs-delta"))
			use_ofs_delta = 1;
		if (strstr(line+45, "side-band-64k"))
			use_sideband = LARGE_PACKET_MAX;
		else if (strstr(line+45, "side-band"))
			use_sideband = DEFAULT_PACKET_MAX;
		if (strstr(line+45, "no-progress"))
			no_progress = 1;

		/* We have sent all our refs already, and the other end
		 * should have chosen out of them; otherwise they are
		 * asking for nonsense.
		 *
		 * Hmph.  We may later want to allow "want" line that
		 * asks for something like "master~10" (symbolic)...
		 * would it make sense?  I don't know.
		 */
		o = lookup_object(sha1_buf);
		if (!o || !(o->flags & OUR_REF))
			die("git-upload-pack: not our ref %s", line+5);
		if (!(o->flags & WANTED)) {
			o->flags |= WANTED;
			add_object_array(o, NULL, &want_obj);
		}
	}
	if (debug_fd)
		write_in_full(debug_fd, "#E\n", 3);
	if (depth == 0 && shallows.nr == 0)
		return;
	if (depth > 0) {
		struct commit_list *result, *backup;
		int i;
		backup = result = get_shallow_commits(&want_obj, depth,
			SHALLOW, NOT_SHALLOW);
		while (result) {
			struct object *object = &result->item->object;
			if (!(object->flags & (CLIENT_SHALLOW|NOT_SHALLOW))) {
				packet_write(1, "shallow %s",
						sha1_to_hex(object->sha1));
				register_shallow(object->sha1);
			}
			result = result->next;
		}
		free_commit_list(backup);
		for (i = 0; i < shallows.nr; i++) {
			struct object *object = shallows.objects[i].item;
			if (object->flags & NOT_SHALLOW) {
				struct commit_list *parents;
				packet_write(1, "unshallow %s",
					sha1_to_hex(object->sha1));
				object->flags &= ~CLIENT_SHALLOW;
				/* make sure the real parents are parsed */
				unregister_shallow(object->sha1);
				object->parsed = 0;
				if (parse_commit((struct commit *)object))
					die("invalid commit");
				parents = ((struct commit *)object)->parents;
				while (parents) {
					add_object_array(&parents->item->object,
							NULL, &want_obj);
					parents = parents->next;
				}
			}
			/* make sure commit traversal conforms to client */
			register_shallow(object->sha1);
		}
		packet_flush(1);
	} else
		if (shallows.nr > 0) {
			int i;
			for (i = 0; i < shallows.nr; i++)
				register_shallow(shallows.objects[i].item->sha1);
		}
	free(shallows.objects);
}

static int send_ref(const char *refname, const unsigned char *sha1, int flag, void *cb_data)
{
	static const char *capabilities = "multi_ack thin-pack side-band"
		" side-band-64k ofs-delta shallow no-progress";
	struct object *o = parse_object(sha1);

	if (!o)
		die("git-upload-pack: cannot find object %s:", sha1_to_hex(sha1));

	if (capabilities)
		packet_write(1, "%s %s%c%s\n", sha1_to_hex(sha1), refname,
			0, capabilities);
	else
		packet_write(1, "%s %s\n", sha1_to_hex(sha1), refname);
	capabilities = NULL;
	if (!(o->flags & OUR_REF)) {
		o->flags |= OUR_REF;
		nr_our_refs++;
	}
	if (o->type == OBJ_TAG) {
		o = deref_tag(o, refname, 0);
		if (o)
			packet_write(1, "%s %s^{}\n", sha1_to_hex(o->sha1), refname);
	}
	return 0;
}

static void upload_pack(void)
{
	reset_timeout();
	head_ref(send_ref, NULL);
	for_each_ref(send_ref, NULL);
	packet_flush(1);
	receive_needs();
	if (want_obj.nr) {
		get_common_commits();
		create_pack_file();
	}
}

int main(int argc, char **argv)
{
	char *dir;
	int i;
	int strict = 0;

	for (i = 1; i < argc; i++) {
		char *arg = argv[i];

		if (arg[0] != '-')
			break;
		if (!strcmp(arg, "--strict")) {
			strict = 1;
			continue;
		}
		if (!prefixcmp(arg, "--timeout=")) {
			timeout = atoi(arg+10);
			continue;
		}
		if (!strcmp(arg, "--")) {
			i++;
			break;
		}
	}

	if (i != argc-1)
		usage(upload_pack_usage);

	setup_path(NULL);

	dir = argv[i];

	if (!enter_repo(dir, strict))
		die("'%s': unable to chdir or not a git archive", dir);
	if (is_repository_shallow())
		die("attempt to fetch/clone from a shallow repository");
	if (getenv("GIT_DEBUG_SEND_PACK"))
		debug_fd = atoi(getenv("GIT_DEBUG_SEND_PACK"));
	upload_pack();
	return 0;
}
Commit	Line	Data
def88e9a LT	1	#include "cache.h"
	2	#include "refs.h"
	3	#include "pkt-line.h"
958c24b1	4	#include "sideband.h"
f6b42a81 JH	5	#include "tag.h"
f6b42a81 JH	6	#include "object.h"
f0243f26	7	#include "commit.h"
77cb17e9	8	#include "exec_cmd.h"
9b8dc263 JS	9	#include "diff.h"
	10	#include "revision.h"
	11	#include "list-objects.h"
cc41fa8d	12	#include "run-command.h"
def88e9a	13
960deccb	14	static const char upload_pack_usage[] = "git-upload-pack [--strict] [--timeout=nn] <dir>";
def88e9a	15
937a515a JH	16	/* bits #0..7 in revision.h, #8..10 in commit.c */
	17	#define THEY_HAVE (1u << 11)
	18	#define OUR_REF (1u << 12)
	19	#define WANTED (1u << 13)
	20	#define COMMON_KNOWN (1u << 14)
	21	#define REACHABLE (1u << 15)
	22
f53514bc JS	23	#define SHALLOW (1u << 16)
	24	#define NOT_SHALLOW (1u << 17)
	25	#define CLIENT_SHALLOW (1u << 18)
	26
3fbe2d54	27	static unsigned long oldest_have;
937a515a	28
96f1e58f	29	static int multi_ack, nr_our_refs;
83a5ad61	30	static int use_thin_pack, use_ofs_delta, no_progress;
b1e9fff7 JH	31	static struct object_array have_obj;
b1e9fff7 JH	32	static struct object_array want_obj;
96f1e58f	33	static unsigned int timeout;
d47f3db7 JH	34	/* 0 for no sideband,
	35	* otherwise maximum packet size (up to 65520 bytes).
	36	*/
96f1e58f	37	static int use_sideband;
49aaddd1	38	static int debug_fd;
960deccb PA	39
	40	static void reset_timeout(void)
	41	{
	42	alarm(timeout);
	43	}
fb9040cc	44
75bfc6c2 LT	45	static int strip(char *line, int len)
	46	{
	47	if (len && line[len-1] == '\n')
	48	line[--len] = 0;
	49	return len;
	50	}
	51
583b7ea3 JH	52	static ssize_t send_client_data(int fd, const char *data, ssize_t sz)
583b7ea3 JH	53	{
958c24b1	54	if (use_sideband)
d47f3db7	55	return send_sideband(1, fd, data, sz, use_sideband);
958c24b1 JH	56	if (fd == 3)
	57	/* emergency quit */
	58	fd = 2;
	59	if (fd == 2) {
93822c22	60	/* XXX: are we happy to lose stuff here? */
958c24b1 JH	61	xwrite(fd, data, sz);
958c24b1 JH	62	return sz;
583b7ea3	63	}
958c24b1	64	return safe_write(fd, data, sz);
583b7ea3 JH	65	}
583b7ea3 JH	66
16befb8b	67	static FILE *pack_pipe = NULL;
9b8dc263 JS	68	static void show_commit(struct commit *commit)
	69	{
	70	if (commit->object.flags & BOUNDARY)
	71	fputc('-', pack_pipe);
	72	if (fputs(sha1_to_hex(commit->object.sha1), pack_pipe) < 0)
	73	die("broken output pipe");
	74	fputc('\n', pack_pipe);
	75	fflush(pack_pipe);
	76	free(commit->buffer);
	77	commit->buffer = NULL;
	78	}
	79
	80	static void show_object(struct object_array_entry *p)
	81	{
	82	/* An object with name "foo\n0000000..." can be used to
	83	* confuse downstream git-pack-objects very badly.
	84	*/
	85	const char *ep = strchr(p->name, '\n');
	86	if (ep) {
	87	fprintf(pack_pipe, "%s %.*s\n", sha1_to_hex(p->item->sha1),
	88	(int) (ep - p->name),
	89	p->name);
	90	}
	91	else
	92	fprintf(pack_pipe, "%s %s\n",
	93	sha1_to_hex(p->item->sha1), p->name);
	94	}
	95
	96	static void show_edge(struct commit *commit)
	97	{
	98	fprintf(pack_pipe, "-%s\n", sha1_to_hex(commit->object.sha1));
	99	}
	100
21edd3f1	101	static int do_rev_list(int fd, void *create_full_pack)
80ccaa78 JS	102	{
	103	int i;
	104	struct rev_info revs;
	105
21edd3f1	106	pack_pipe = fdopen(fd, "w");
80ccaa78 JS	107	if (create_full_pack)
	108	use_thin_pack = 0; /* no point doing it */
	109	init_revisions(&revs, NULL);
	110	revs.tag_objects = 1;
	111	revs.tree_objects = 1;
	112	revs.blob_objects = 1;
	113	if (use_thin_pack)
	114	revs.edge_hint = 1;
	115
	116	if (create_full_pack) {
	117	const char *args[] = {"rev-list", "--all", NULL};
	118	setup_revisions(2, args, &revs, NULL);
	119	} else {
	120	for (i = 0; i < want_obj.nr; i++) {
	121	struct object *o = want_obj.objects[i].item;
	122	/* why??? */
	123	o->flags &= ~UNINTERESTING;
	124	add_pending_object(&revs, o, NULL);
	125	}
	126	for (i = 0; i < have_obj.nr; i++) {
	127	struct object *o = have_obj.objects[i].item;
	128	o->flags \|= UNINTERESTING;
	129	add_pending_object(&revs, o, NULL);
	130	}
	131	setup_revisions(0, NULL, &revs, NULL);
	132	}
3d51e1b5 MK	133	if (prepare_revision_walk(&revs))
3d51e1b5 MK	134	die("revision walk setup failed");
80ccaa78 JS	135	mark_edges_uninteresting(revs.commits, &revs, show_edge);
80ccaa78 JS	136	traverse_commit_list(&revs, show_commit, show_object);
21edd3f1	137	return 0;
80ccaa78 JS	138	}
80ccaa78 JS	139
fb9040cc LT	140	static void create_pack_file(void)
fb9040cc LT	141	{
21edd3f1	142	struct async rev_list;
cc41fa8d	143	struct child_process pack_objects;
b1e9fff7	144	int create_full_pack = (nr_our_refs == want_obj.nr && !have_obj.nr);
363b7817	145	char data[8193], progress[128];
583b7ea3 JH	146	char abort_msg[] = "aborting due to possible repository "
583b7ea3 JH	147	"corruption on the remote side.";
b1c71b72	148	int buffered = -1;
4c324c00	149	ssize_t sz;
cc41fa8d JS	150	const char *argv[10];
cc41fa8d JS	151	int arg = 0;
75bfc6c2	152
21edd3f1 JS	153	rev_list.proc = do_rev_list;
	154	/* .data is just a boolean: any non-NULL value will do */
	155	rev_list.data = create_full_pack ? &rev_list : NULL;
	156	if (start_async(&rev_list))
75bfc6c2 LT	157	die("git-upload-pack: unable to fork git-rev-list");
75bfc6c2 LT	158
cc41fa8d JS	159	argv[arg++] = "pack-objects";
	160	argv[arg++] = "--stdout";
	161	if (!no_progress)
	162	argv[arg++] = "--progress";
	163	if (use_ofs_delta)
	164	argv[arg++] = "--delta-base-offset";
	165	argv[arg++] = NULL;
	166
	167	memset(&pack_objects, 0, sizeof(pack_objects));
21edd3f1	168	pack_objects.in = rev_list.out; /* start_command closes it */
cc41fa8d JS	169	pack_objects.out = -1;
	170	pack_objects.err = -1;
	171	pack_objects.git_cmd = 1;
	172	pack_objects.argv = argv;
21edd3f1	173
4c324c00	174	if (start_command(&pack_objects))
b1c71b72	175	die("git-upload-pack: unable to fork git-pack-objects");
b1c71b72	176
cc41fa8d JS	177	/* We read from pack_objects.err to capture stderr output for
cc41fa8d JS	178	* progress bar, and pack_objects.out to capture the pack data.
b1c71b72	179	*/
b1c71b72 JH	180
b1c71b72 JH	181	while (1) {
b1c71b72	182	struct pollfd pfd[2];
363b7817	183	int pe, pu, pollsize;
b1c71b72	184
0d516ada ML	185	reset_timeout();
0d516ada ML	186
b1c71b72	187	pollsize = 0;
363b7817	188	pe = pu = -1;
b1c71b72	189
cc41fa8d JS	190	if (0 <= pack_objects.out) {
cc41fa8d JS	191	pfd[pollsize].fd = pack_objects.out;
b1c71b72 JH	192	pfd[pollsize].events = POLLIN;
	193	pu = pollsize;
	194	pollsize++;
	195	}
cc41fa8d JS	196	if (0 <= pack_objects.err) {
cc41fa8d JS	197	pfd[pollsize].fd = pack_objects.err;
363b7817 JH	198	pfd[pollsize].events = POLLIN;
	199	pe = pollsize;
	200	pollsize++;
	201	}
b1c71b72	202
4c324c00 JS	203	if (!pollsize)
	204	break;
	205
	206	if (poll(pfd, pollsize, -1) < 0) {
	207	if (errno != EINTR) {
	208	error("poll failed, resuming: %s",
	209	strerror(errno));
	210	sleep(1);
b1c71b72	211	}
4c324c00 JS	212	continue;
	213	}
	214	if (0 <= pu && (pfd[pu].revents & (POLLIN\|POLLHUP))) {
	215	/* Data ready; we keep the last byte to ourselves
	216	* in case we detect broken rev-list, so that we
	217	* can leave the stream corrupted. This is
	218	* unfortunate -- unpack-objects would happily
	219	* accept a valid packdata with trailing garbage,
	220	* so appending garbage after we pass all the
	221	* pack data is not good enough to signal
	222	* breakage to downstream.
	223	*/
	224	char *cp = data;
	225	ssize_t outsz = 0;
	226	if (0 <= buffered) {
	227	*cp++ = buffered;
	228	outsz++;
b1c71b72	229	}
4c324c00 JS	230	sz = xread(pack_objects.out, cp,
	231	sizeof(data) - outsz);
	232	if (0 < sz)
	233	;
	234	else if (sz == 0) {
	235	close(pack_objects.out);
	236	pack_objects.out = -1;
363b7817	237	}
4c324c00 JS	238	else
	239	goto fail;
	240	sz += outsz;
	241	if (1 < sz) {
	242	buffered = data[sz-1] & 0xFF;
	243	sz--;
b1c71b72	244	}
4c324c00 JS	245	else
	246	buffered = -1;
	247	sz = send_client_data(1, data, sz);
	248	if (sz < 0)
b1c71b72	249	goto fail;
4c324c00 JS	250	}
	251	if (0 <= pe && (pfd[pe].revents & (POLLIN\|POLLHUP))) {
	252	/* Status ready; we ship that in the side-band
	253	* or dump to the standard error.
	254	*/
	255	sz = xread(pack_objects.err, progress,
	256	sizeof(progress));
	257	if (0 < sz)
	258	send_client_data(2, progress, sz);
	259	else if (sz == 0) {
	260	close(pack_objects.err);
	261	pack_objects.err = -1;
b1c71b72	262	}
4c324c00 JS	263	else
4c324c00 JS	264	goto fail;
b1c71b72	265	}
4c324c00	266	}
b1c71b72	267
4c324c00 JS	268	if (finish_command(&pack_objects)) {
	269	error("git-upload-pack: git-pack-objects died with error.");
	270	goto fail;
	271	}
	272	if (finish_async(&rev_list))
	273	goto fail; /* error was already reported */
b1c71b72	274
4c324c00 JS	275	/* flush the data */
	276	if (0 <= buffered) {
	277	data[0] = buffered;
	278	sz = send_client_data(1, data, 1);
	279	if (sz < 0)
	280	goto fail;
	281	fprintf(stderr, "flushed.\n");
b1c71b72	282	}
4c324c00 JS	283	if (use_sideband)
	284	packet_flush(1);
	285	return;
	286
b1c71b72	287	fail:
583b7ea3 JH	288	send_client_data(3, abort_msg, sizeof(abort_msg));
583b7ea3 JH	289	die("git-upload-pack: %s", abort_msg);
fb9040cc LT	290	}
fb9040cc LT	291
def88e9a LT	292	static int got_sha1(char hex, unsigned char sha1)
def88e9a LT	293	{
b1e9fff7	294	struct object *o;
937a515a	295	int we_knew_they_have = 0;
b1e9fff7	296
def88e9a LT	297	if (get_sha1_hex(hex, sha1))
def88e9a LT	298	die("git-upload-pack: expected SHA1 object, got '%s'", hex);
fb9040cc	299	if (!has_sha1_file(sha1))
937a515a	300	return -1;
b1e9fff7 JH	301
	302	o = lookup_object(sha1);
	303	if (!(o && o->parsed))
	304	o = parse_object(sha1);
	305	if (!o)
	306	die("oops (%s)", sha1_to_hex(sha1));
182a8dab	307	if (o->type == OBJ_COMMIT) {
b1e9fff7	308	struct commit_list *parents;
937a515a	309	struct commit commit = (struct commit )o;
b1e9fff7	310	if (o->flags & THEY_HAVE)
937a515a JH	311	we_knew_they_have = 1;
	312	else
	313	o->flags \|= THEY_HAVE;
	314	if (!oldest_have \|\| (commit->date < oldest_have))
	315	oldest_have = commit->date;
	316	for (parents = commit->parents;
b1e9fff7 JH	317	parents;
	318	parents = parents->next)
	319	parents->item->object.flags \|= THEY_HAVE;
fb9040cc	320	}
937a515a JH	321	if (!we_knew_they_have) {
	322	add_object_array(o, NULL, &have_obj);
	323	return 1;
	324	}
	325	return 0;
	326	}
	327
	328	static int reachable(struct commit *want)
	329	{
	330	struct commit_list *work = NULL;
	331
	332	insert_by_date(want, &work);
	333	while (work) {
	334	struct commit_list *list = work->next;
	335	struct commit *commit = work->item;
	336	free(work);
	337	work = list;
	338
	339	if (commit->object.flags & THEY_HAVE) {
	340	want->object.flags \|= COMMON_KNOWN;
	341	break;
	342	}
	343	if (!commit->object.parsed)
	344	parse_object(commit->object.sha1);
	345	if (commit->object.flags & REACHABLE)
	346	continue;
	347	commit->object.flags \|= REACHABLE;
	348	if (commit->date < oldest_have)
	349	continue;
	350	for (list = commit->parents; list; list = list->next) {
	351	struct commit *parent = list->item;
	352	if (!(parent->object.flags & REACHABLE))
	353	insert_by_date(parent, &work);
	354	}
	355	}
	356	want->object.flags \|= REACHABLE;
	357	clear_commit_marks(want, REACHABLE);
	358	free_commit_list(work);
	359	return (want->object.flags & COMMON_KNOWN);
	360	}
	361
	362	static int ok_to_give_up(void)
	363	{
	364	int i;
	365
	366	if (!have_obj.nr)
	367	return 0;
	368
	369	for (i = 0; i < want_obj.nr; i++) {
	370	struct object *want = want_obj.objects[i].item;
	371
	372	if (want->flags & COMMON_KNOWN)
	373	continue;
	374	want = deref_tag(want, "a want line", 0);
	375	if (!want \|\| want->type != OBJ_COMMIT) {
	376	/* no way to tell if this is reachable by
	377	* looking at the ancestry chain alone, so
	378	* leave a note to ourselves not to worry about
	379	* this object anymore.
	380	*/
	381	want_obj.objects[i].item->flags \|= COMMON_KNOWN;
	382	continue;
	383	}
	384	if (!reachable((struct commit *)want))
385	return 0;
386	}
fb9040cc	387	return 1;
def88e9a LT	388	}
	389
	390	static int get_common_commits(void)
	391	{
	392	static char line[1000];
c04c4e57 JH	393	unsigned char sha1[20];
c04c4e57 JH	394	char hex[41], last_hex[41];
def88e9a LT	395	int len;
def88e9a LT	396
f0243f26 JS	397	save_commit_buffer = 0;
f0243f26 JS	398
def88e9a LT	399	for(;;) {
def88e9a LT	400	len = packet_read_line(0, line, sizeof(line));
960deccb	401	reset_timeout();
def88e9a LT	402
def88e9a LT	403	if (!len) {
b1e9fff7	404	if (have_obj.nr == 0 \|\| multi_ack)
1bd8c8f0	405	packet_write(1, "NAK\n");
def88e9a LT	406	continue;
def88e9a LT	407	}
75bfc6c2	408	len = strip(line, len);
cc44c765	409	if (!prefixcmp(line, "have ")) {
937a515a JH	410	switch (got_sha1(line+5, sha1)) {
	411	case -1: /* they have what we do not */
	412	if (multi_ack && ok_to_give_up())
	413	packet_write(1, "ACK %s continue\n",
	414	sha1_to_hex(sha1));
	415	break;
	416	default:
c04c4e57 JH	417	memcpy(hex, sha1_to_hex(sha1), 41);
	418	if (multi_ack) {
	419	const char *msg = "ACK %s continue\n";
	420	packet_write(1, msg, hex);
	421	memcpy(last_hex, hex, 41);
	422	}
	423	else if (have_obj.nr == 1)
	424	packet_write(1, "ACK %s\n", hex);
937a515a	425	break;
af2d3aa4	426	}
def88e9a LT	427	continue;
	428	}
	429	if (!strcmp(line, "done")) {
b1e9fff7	430	if (have_obj.nr > 0) {
1bd8c8f0	431	if (multi_ack)
c04c4e57	432	packet_write(1, "ACK %s\n", last_hex);
1bd8c8f0 JS	433	return 0;
1bd8c8f0 JS	434	}
def88e9a LT	435	packet_write(1, "NAK\n");
	436	return -1;
	437	}
	438	die("git-upload-pack: expected SHA1 list, got '%s'", line);
	439	}
def88e9a LT	440	}
def88e9a LT	441
b1e9fff7	442	static void receive_needs(void)
fb9040cc	443	{
ed09aef0	444	struct object_array shallows = {0, 0, NULL};
fb9040cc	445	static char line[1000];
016e6ccb	446	int len, depth = 0;
fb9040cc	447
49aaddd1 SP	448	if (debug_fd)
49aaddd1 SP	449	write_in_full(debug_fd, "#S\n", 3);
fb9040cc	450	for (;;) {
565ebbf7	451	struct object *o;
6ece0d30	452	unsigned char sha1_buf[20];
fb9040cc	453	len = packet_read_line(0, line, sizeof(line));
960deccb	454	reset_timeout();
fb9040cc	455	if (!len)
ed09aef0	456	break;
49aaddd1 SP	457	if (debug_fd)
49aaddd1 SP	458	write_in_full(debug_fd, line, len);
e091eb93	459
599065a3	460	if (!prefixcmp(line, "shallow ")) {
ed09aef0 JS	461	unsigned char sha1[20];
ed09aef0 JS	462	struct object *object;
f53514bc	463	use_thin_pack = 0;
ed09aef0 JS	464	if (get_sha1(line + 8, sha1))
	465	die("invalid shallow line: %s", line);
	466	object = parse_object(sha1);
	467	if (!object)
	468	die("did not find object for %s", line);
f53514bc	469	object->flags \|= CLIENT_SHALLOW;
ed09aef0 JS	470	add_object_array(object, NULL, &shallows);
	471	continue;
	472	}
599065a3	473	if (!prefixcmp(line, "deepen ")) {
016e6ccb	474	char *end;
f53514bc	475	use_thin_pack = 0;
016e6ccb JS	476	depth = strtol(line + 7, &end, 0);
	477	if (end == line + 7 \|\| depth <= 0)
	478	die("Invalid deepen: %s", line);
	479	continue;
	480	}
599065a3	481	if (prefixcmp(line, "want ") \|\|
6ece0d30	482	get_sha1_hex(line+5, sha1_buf))
e091eb93 JH	483	die("git-upload-pack: protocol error, "
e091eb93 JH	484	"expected to get sha, not '%s'", line);
1bd8c8f0 JS	485	if (strstr(line+45, "multi_ack"))
1bd8c8f0 JS	486	multi_ack = 1;
b19696c2 JH	487	if (strstr(line+45, "thin-pack"))
b19696c2 JH	488	use_thin_pack = 1;
e4fe4b8e NP	489	if (strstr(line+45, "ofs-delta"))
e4fe4b8e NP	490	use_ofs_delta = 1;
d47f3db7 JH	491	if (strstr(line+45, "side-band-64k"))
	492	use_sideband = LARGE_PACKET_MAX;
	493	else if (strstr(line+45, "side-band"))
	494	use_sideband = DEFAULT_PACKET_MAX;
b0e90897 JS	495	if (strstr(line+45, "no-progress"))
b0e90897 JS	496	no_progress = 1;
565ebbf7 JH	497
	498	/* We have sent all our refs already, and the other end
	499	* should have chosen out of them; otherwise they are
	500	* asking for nonsense.
	501	*
	502	* Hmph. We may later want to allow "want" line that
	503	* asks for something like "master~10" (symbolic)...
	504	* would it make sense? I don't know.
	505	*/
	506	o = lookup_object(sha1_buf);
	507	if (!o \|\| !(o->flags & OUR_REF))
	508	die("git-upload-pack: not our ref %s", line+5);
	509	if (!(o->flags & WANTED)) {
	510	o->flags \|= WANTED;
b1e9fff7	511	add_object_array(o, NULL, &want_obj);
565ebbf7	512	}
fb9040cc	513	}
49aaddd1 SP	514	if (debug_fd)
49aaddd1 SP	515	write_in_full(debug_fd, "#E\n", 3);
f53514bc JS	516	if (depth == 0 && shallows.nr == 0)
f53514bc JS	517	return;
016e6ccb JS	518	if (depth > 0) {
016e6ccb JS	519	struct commit_list result, backup;
f53514bc JS	520	int i;
	521	backup = result = get_shallow_commits(&want_obj, depth,
	522	SHALLOW, NOT_SHALLOW);
016e6ccb	523	while (result) {
f53514bc	524	struct object *object = &result->item->object;
1f2de769	525	if (!(object->flags & (CLIENT_SHALLOW\|NOT_SHALLOW))) {
f53514bc JS	526	packet_write(1, "shallow %s",
	527	sha1_to_hex(object->sha1));
	528	register_shallow(object->sha1);
	529	}
016e6ccb JS	530	result = result->next;
	531	}
	532	free_commit_list(backup);
f53514bc JS	533	for (i = 0; i < shallows.nr; i++) {
	534	struct object *object = shallows.objects[i].item;
	535	if (object->flags & NOT_SHALLOW) {
	536	struct commit_list *parents;
	537	packet_write(1, "unshallow %s",
	538	sha1_to_hex(object->sha1));
	539	object->flags &= ~CLIENT_SHALLOW;
	540	/* make sure the real parents are parsed */
	541	unregister_shallow(object->sha1);
176d45cb	542	object->parsed = 0;
dec38c81 MK	543	if (parse_commit((struct commit *)object))
dec38c81 MK	544	die("invalid commit");
f53514bc JS	545	parents = ((struct commit *)object)->parents;
	546	while (parents) {
	547	add_object_array(&parents->item->object,
	548	NULL, &want_obj);
	549	parents = parents->next;
	550	}
	551	}
	552	/* make sure commit traversal conforms to client */
	553	register_shallow(object->sha1);
	554	}
	555	packet_flush(1);
	556	} else
	557	if (shallows.nr > 0) {
	558	int i;
	559	for (i = 0; i < shallows.nr; i++)
	560	register_shallow(shallows.objects[i].item->sha1);
	561	}
	562	free(shallows.objects);
fb9040cc LT	563	}
fb9040cc LT	564
8da19775	565	static int send_ref(const char refname, const unsigned char sha1, int flag, void *cb_data)
def88e9a	566	{
ed09aef0	567	static const char *capabilities = "multi_ack thin-pack side-band"
b0e90897	568	" side-band-64k ofs-delta shallow no-progress";
f6b42a81 JH	569	struct object *o = parse_object(sha1);
f6b42a81 JH	570
b5b16990 CW	571	if (!o)
	572	die("git-upload-pack: cannot find object %s:", sha1_to_hex(sha1));
	573
1f5881bb JS	574	if (capabilities)
	575	packet_write(1, "%s %s%c%s\n", sha1_to_hex(sha1), refname,
	576	0, capabilities);
	577	else
	578	packet_write(1, "%s %s\n", sha1_to_hex(sha1), refname);
	579	capabilities = NULL;
565ebbf7 JH	580	if (!(o->flags & OUR_REF)) {
	581	o->flags \|= OUR_REF;
	582	nr_our_refs++;
	583	}
1974632c	584	if (o->type == OBJ_TAG) {
9534f40b	585	o = deref_tag(o, refname, 0);
affeef12 MK	586	if (o)
affeef12 MK	587	packet_write(1, "%s %s^{}\n", sha1_to_hex(o->sha1), refname);
f6b42a81	588	}
def88e9a LT	589	return 0;
	590	}
	591
59076eba	592	static void upload_pack(void)
def88e9a	593	{
960deccb	594	reset_timeout();
cb5d709f JH	595	head_ref(send_ref, NULL);
cb5d709f JH	596	for_each_ref(send_ref, NULL);
def88e9a	597	packet_flush(1);
b1e9fff7	598	receive_needs();
59076eba DR	599	if (want_obj.nr) {
	600	get_common_commits();
	601	create_pack_file();
	602	}
def88e9a LT	603	}
	604
	605	int main(int argc, char **argv)
	606	{
8d630132	607	char *dir;
960deccb PA	608	int i;
	609	int strict = 0;
	610
	611	for (i = 1; i < argc; i++) {
	612	char *arg = argv[i];
	613
	614	if (arg[0] != '-')
	615	break;
	616	if (!strcmp(arg, "--strict")) {
	617	strict = 1;
	618	continue;
	619	}
cc44c765	620	if (!prefixcmp(arg, "--timeout=")) {
960deccb PA	621	timeout = atoi(arg+10);
	622	continue;
	623	}
	624	if (!strcmp(arg, "--")) {
	625	i++;
	626	break;
	627	}
	628	}
a6080a0a	629
960deccb	630	if (i != argc-1)
def88e9a	631	usage(upload_pack_usage);
04b33055 JS	632
	633	setup_path(NULL);
	634
960deccb	635	dir = argv[i];
113b9475	636
8d630132 AE	637	if (!enter_repo(dir, strict))
8d630132 AE	638	die("'%s': unable to chdir or not a git archive", dir);
a0022eeb JH	639	if (is_repository_shallow())
a0022eeb JH	640	die("attempt to fetch/clone from a shallow repository");
49aaddd1 SP	641	if (getenv("GIT_DEBUG_SEND_PACK"))
49aaddd1 SP	642	debug_fd = atoi(getenv("GIT_DEBUG_SEND_PACK"));
def88e9a LT	643	upload_pack();
	644	return 0;
	645	}