[thirdparty/git.git] / builtin-fetch.c

/*
 * "git fetch"
 */
#include "cache.h"
#include "refs.h"
#include "commit.h"
#include "builtin.h"
#include "path-list.h"
#include "remote.h"
#include "transport.h"
#include "run-command.h"
#include "parse-options.h"

static const char * const builtin_fetch_usage[] = {
	"git-fetch [options] [<repository> <refspec>...]",
	NULL
};

enum {
	TAGS_UNSET = 0,
	TAGS_DEFAULT = 1,
	TAGS_SET = 2
};

static int append, force, keep, update_head_ok, verbose, quiet;
static int tags = TAGS_DEFAULT;
static const char *depth;
static const char *upload_pack;
static struct strbuf default_rla = STRBUF_INIT;
static struct transport *transport;

static struct option builtin_fetch_options[] = {
	OPT__QUIET(&quiet),
	OPT__VERBOSE(&verbose),
	OPT_BOOLEAN('a', "append", &append,
		    "append to .git/FETCH_HEAD instead of overwriting"),
	OPT_STRING(0, "upload-pack", &upload_pack, "PATH",
		   "path to upload pack on remote end"),
	OPT_BOOLEAN('f', "force", &force,
		    "force overwrite of local branch"),
	OPT_SET_INT('t', "tags", &tags,
		    "fetch all tags and associated objects", TAGS_SET),
	OPT_SET_INT('n', NULL, &tags,
		    "do not fetch all tags (--no-tags)", TAGS_UNSET),
	OPT_BOOLEAN('k', "keep", &keep, "keep downloaded pack"),
	OPT_BOOLEAN('u', "update-head-ok", &update_head_ok,
		    "allow updating of HEAD ref"),
	OPT_STRING(0, "depth", &depth, "DEPTH",
		   "deepen history of shallow clone"),
	OPT_END()
};

static void unlock_pack(void)
{
	if (transport)
		transport_unlock_pack(transport);
}

static void unlock_pack_on_signal(int signo)
{
	unlock_pack();
	signal(SIGINT, SIG_DFL);
	raise(signo);
}

static void add_merge_config(struct ref **head,
			   const struct ref *remote_refs,
		           struct branch *branch,
		           struct ref ***tail)
{
	int i;

	for (i = 0; i < branch->merge_nr; i++) {
		struct ref *rm, **old_tail = *tail;
		struct refspec refspec;

		for (rm = *head; rm; rm = rm->next) {
			if (branch_merge_matches(branch, i, rm->name)) {
				rm->merge = 1;
				break;
			}
		}
		if (rm)
			continue;

		/*
		 * Not fetched to a tracking branch?  We need to fetch
		 * it anyway to allow this branch's "branch.$name.merge"
		 * to be honored by git-pull, but we do not have to
		 * fail if branch.$name.merge is misconfigured to point
		 * at a nonexisting branch.  If we were indeed called by
		 * git-pull, it will notice the misconfiguration because
		 * there is no entry in the resulting FETCH_HEAD marked
		 * for merging.
		 */
		refspec.src = branch->merge[i]->src;
		refspec.dst = NULL;
		refspec.pattern = 0;
		refspec.force = 0;
		get_fetch_map(remote_refs, &refspec, tail, 1);
		for (rm = *old_tail; rm; rm = rm->next)
			rm->merge = 1;
	}
}

static void find_non_local_tags(struct transport *transport,
			struct ref **head,
			struct ref ***tail);

static struct ref *get_ref_map(struct transport *transport,
			       struct refspec *refs, int ref_count, int tags,
			       int *autotags)
{
	int i;
	struct ref *rm;
	struct ref *ref_map = NULL;
	struct ref **tail = &ref_map;

	const struct ref *remote_refs = transport_get_remote_refs(transport);

	if (ref_count || tags == TAGS_SET) {
		for (i = 0; i < ref_count; i++) {
			get_fetch_map(remote_refs, &refs[i], &tail, 0);
			if (refs[i].dst && refs[i].dst[0])
				*autotags = 1;
		}
		/* Merge everything on the command line, but not --tags */
		for (rm = ref_map; rm; rm = rm->next)
			rm->merge = 1;
		if (tags == TAGS_SET) {
			struct refspec refspec;
			refspec.src = "refs/tags/";
			refspec.dst = "refs/tags/";
			refspec.pattern = 1;
			refspec.force = 0;
			get_fetch_map(remote_refs, &refspec, &tail, 0);
		}
	} else {
		/* Use the defaults */
		struct remote *remote = transport->remote;
		struct branch *branch = branch_get(NULL);
		int has_merge = branch_has_merge_config(branch);
		if (remote && (remote->fetch_refspec_nr || has_merge)) {
			for (i = 0; i < remote->fetch_refspec_nr; i++) {
				get_fetch_map(remote_refs, &remote->fetch[i], &tail, 0);
				if (remote->fetch[i].dst &&
				    remote->fetch[i].dst[0])
					*autotags = 1;
				if (!i && !has_merge && ref_map &&
				    !remote->fetch[0].pattern)
					ref_map->merge = 1;
			}
			/*
			 * if the remote we're fetching from is the same
			 * as given in branch.<name>.remote, we add the
			 * ref given in branch.<name>.merge, too.
			 */
			if (has_merge &&
			    !strcmp(branch->remote_name, remote->name))
				add_merge_config(&ref_map, remote_refs, branch, &tail);
		} else {
			ref_map = get_remote_ref(remote_refs, "HEAD");
			if (!ref_map)
				die("Couldn't find remote ref HEAD");
			ref_map->merge = 1;
			tail = &ref_map->next;
		}
	}
	if (tags == TAGS_DEFAULT && *autotags)
		find_non_local_tags(transport, &ref_map, &tail);
	ref_remove_duplicates(ref_map);

	return ref_map;
}

static int s_update_ref(const char *action,
			struct ref *ref,
			int check_old)
{
	char msg[1024];
	char *rla = getenv("GIT_REFLOG_ACTION");
	static struct ref_lock *lock;

	if (!rla)
		rla = default_rla.buf;
	snprintf(msg, sizeof(msg), "%s: %s", rla, action);
	lock = lock_any_ref_for_update(ref->name,
				       check_old ? ref->old_sha1 : NULL, 0);
	if (!lock)
		return 1;
	if (write_ref_sha1(lock, ref->new_sha1, msg) < 0)
		return 1;
	return 0;
}

#define SUMMARY_WIDTH (2 * DEFAULT_ABBREV + 3)
#define REFCOL_WIDTH  10

static int update_local_ref(struct ref *ref,
			    const char *remote,
			    int verbose,
			    char *display)
{
	struct commit *current = NULL, *updated;
	enum object_type type;
	struct branch *current_branch = branch_get(NULL);
	const char *pretty_ref = ref->name + (
		!prefixcmp(ref->name, "refs/heads/") ? 11 :
		!prefixcmp(ref->name, "refs/tags/") ? 10 :
		!prefixcmp(ref->name, "refs/remotes/") ? 13 :
		0);

	*display = 0;
	type = sha1_object_info(ref->new_sha1, NULL);
	if (type < 0)
		die("object %s not found", sha1_to_hex(ref->new_sha1));

	if (!*ref->name) {
		/* Not storing */
		if (verbose)
			sprintf(display, "* branch %s -> FETCH_HEAD", remote);
		return 0;
	}

	if (!hashcmp(ref->old_sha1, ref->new_sha1)) {
		if (verbose)
			sprintf(display, "= %-*s %-*s -> %s", SUMMARY_WIDTH,
				"[up to date]", REFCOL_WIDTH, remote,
				pretty_ref);
		return 0;
	}

	if (current_branch &&
	    !strcmp(ref->name, current_branch->name) &&
	    !(update_head_ok || is_bare_repository()) &&
	    !is_null_sha1(ref->old_sha1)) {
		/*
		 * If this is the head, and it's not okay to update
		 * the head, and the old value of the head isn't empty...
		 */
		sprintf(display, "! %-*s %-*s -> %s  (can't fetch in current branch)",
			SUMMARY_WIDTH, "[rejected]", REFCOL_WIDTH, remote,
			pretty_ref);
		return 1;
	}

	if (!is_null_sha1(ref->old_sha1) &&
	    !prefixcmp(ref->name, "refs/tags/")) {
		sprintf(display, "- %-*s %-*s -> %s",
			SUMMARY_WIDTH, "[tag update]", REFCOL_WIDTH, remote,
			pretty_ref);
		return s_update_ref("updating tag", ref, 0);
	}

	current = lookup_commit_reference_gently(ref->old_sha1, 1);
	updated = lookup_commit_reference_gently(ref->new_sha1, 1);
	if (!current || !updated) {
		const char *msg;
		const char *what;
		if (!strncmp(ref->name, "refs/tags/", 10)) {
			msg = "storing tag";
			what = "[new tag]";
		}
		else {
			msg = "storing head";
			what = "[new branch]";
		}

		sprintf(display, "* %-*s %-*s -> %s", SUMMARY_WIDTH, what,
			REFCOL_WIDTH, remote, pretty_ref);
		return s_update_ref(msg, ref, 0);
	}

	if (in_merge_bases(current, &updated, 1)) {
		char quickref[83];
		strcpy(quickref, find_unique_abbrev(current->object.sha1, DEFAULT_ABBREV));
		strcat(quickref, "..");
		strcat(quickref, find_unique_abbrev(ref->new_sha1, DEFAULT_ABBREV));
		sprintf(display, "  %-*s %-*s -> %s", SUMMARY_WIDTH, quickref,
			REFCOL_WIDTH, remote, pretty_ref);
		return s_update_ref("fast forward", ref, 1);
	} else if (force || ref->force) {
		char quickref[84];
		strcpy(quickref, find_unique_abbrev(current->object.sha1, DEFAULT_ABBREV));
		strcat(quickref, "...");
		strcat(quickref, find_unique_abbrev(ref->new_sha1, DEFAULT_ABBREV));
		sprintf(display, "+ %-*s %-*s -> %s  (forced update)",
			SUMMARY_WIDTH, quickref, REFCOL_WIDTH, remote, pretty_ref);
		return s_update_ref("forced-update", ref, 1);
	} else {
		sprintf(display, "! %-*s %-*s -> %s  (non fast forward)",
			SUMMARY_WIDTH, "[rejected]", REFCOL_WIDTH, remote,
			pretty_ref);
		return 1;
	}
}

static int store_updated_refs(const char *url, struct ref *ref_map)
{
	FILE *fp;
	struct commit *commit;
	int url_len, i, note_len, shown_url = 0;
	char note[1024];
	const char *what, *kind;
	struct ref *rm;
	char *filename = git_path("FETCH_HEAD");

	fp = fopen(filename, "a");
	if (!fp)
		return error("cannot open %s: %s\n", filename, strerror(errno));
	for (rm = ref_map; rm; rm = rm->next) {
		struct ref *ref = NULL;

		if (rm->peer_ref) {
			ref = xcalloc(1, sizeof(*ref) + strlen(rm->peer_ref->name) + 1);
			strcpy(ref->name, rm->peer_ref->name);
			hashcpy(ref->old_sha1, rm->peer_ref->old_sha1);
			hashcpy(ref->new_sha1, rm->old_sha1);
			ref->force = rm->peer_ref->force;
		}

		commit = lookup_commit_reference_gently(rm->old_sha1, 1);
		if (!commit)
			rm->merge = 0;

		if (!strcmp(rm->name, "HEAD")) {
			kind = "";
			what = "";
		}
		else if (!prefixcmp(rm->name, "refs/heads/")) {
			kind = "branch";
			what = rm->name + 11;
		}
		else if (!prefixcmp(rm->name, "refs/tags/")) {
			kind = "tag";
			what = rm->name + 10;
		}
		else if (!prefixcmp(rm->name, "refs/remotes/")) {
			kind = "remote branch";
			what = rm->name + 13;
		}
		else {
			kind = "";
			what = rm->name;
		}

		url_len = strlen(url);
		for (i = url_len - 1; url[i] == '/' && 0 <= i; i--)
			;
		url_len = i + 1;
		if (4 < i && !strncmp(".git", url + i - 3, 4))
			url_len = i - 3;

		note_len = 0;
		if (*what) {
			if (*kind)
				note_len += sprintf(note + note_len, "%s ",
						    kind);
			note_len += sprintf(note + note_len, "'%s' of ", what);
		}
		note_len += sprintf(note + note_len, "%.*s", url_len, url);
		fprintf(fp, "%s\t%s\t%s\n",
			sha1_to_hex(commit ? commit->object.sha1 :
				    rm->old_sha1),
			rm->merge ? "" : "not-for-merge",
			note);

		if (ref) {
			update_local_ref(ref, what, verbose, note);
			if (*note) {
				if (!shown_url) {
					fprintf(stderr, "From %.*s\n",
							url_len, url);
					shown_url = 1;
				}
				fprintf(stderr, " %s\n", note);
			}
		}
	}
	fclose(fp);
	return 0;
}

/*
 * We would want to bypass the object transfer altogether if
 * everything we are going to fetch already exists and connected
 * locally.
 *
 * The refs we are going to fetch are in to_fetch (nr_heads in
 * total).  If running
 *
 *  $ git-rev-list --objects to_fetch[0] to_fetch[1] ... --not --all
 *
 * does not error out, that means everything reachable from the
 * refs we are going to fetch exists and is connected to some of
 * our existing refs.
 */
static int quickfetch(struct ref *ref_map)
{
	struct child_process revlist;
	struct ref *ref;
	char **argv;
	int i, err;

	/*
	 * If we are deepening a shallow clone we already have these
	 * objects reachable.  Running rev-list here will return with
	 * a good (0) exit status and we'll bypass the fetch that we
	 * really need to perform.  Claiming failure now will ensure
	 * we perform the network exchange to deepen our history.
	 */
	if (depth)
		return -1;

	for (i = 0, ref = ref_map; ref; ref = ref->next)
		i++;
	if (!i)
		return 0;

	argv = xmalloc(sizeof(*argv) * (i + 6));
	i = 0;
	argv[i++] = xstrdup("rev-list");
	argv[i++] = xstrdup("--quiet");
	argv[i++] = xstrdup("--objects");
	for (ref = ref_map; ref; ref = ref->next)
		argv[i++] = xstrdup(sha1_to_hex(ref->old_sha1));
	argv[i++] = xstrdup("--not");
	argv[i++] = xstrdup("--all");
	argv[i++] = NULL;

	memset(&revlist, 0, sizeof(revlist));
	revlist.argv = (const char**)argv;
	revlist.git_cmd = 1;
	revlist.no_stdin = 1;
	revlist.no_stdout = 1;
	revlist.no_stderr = 1;
	err = run_command(&revlist);

	for (i = 0; argv[i]; i++)
		free(argv[i]);
	free(argv);
	return err;
}

static int fetch_refs(struct transport *transport, struct ref *ref_map)
{
	int ret = quickfetch(ref_map);
	if (ret)
		ret = transport_fetch_refs(transport, ref_map);
	if (!ret)
		ret |= store_updated_refs(transport->url, ref_map);
	transport_unlock_pack(transport);
	return ret;
}

static int add_existing(const char *refname, const unsigned char *sha1,
			int flag, void *cbdata)
{
	struct path_list *list = (struct path_list *)cbdata;
	path_list_insert(refname, list);
	return 0;
}

static int will_fetch(struct ref **head, const unsigned char *sha1)
{
	struct ref *rm = *head;
	while (rm) {
		if (!hashcmp(rm->old_sha1, sha1))
			return 1;
		rm = rm->next;
	}
	return 0;
}

static void find_non_local_tags(struct transport *transport,
			struct ref **head,
			struct ref ***tail)
{
	struct path_list existing_refs = { NULL, 0, 0, 0 };
	struct path_list new_refs = { NULL, 0, 0, 1 };
	char *ref_name;
	int ref_name_len;
	const unsigned char *ref_sha1;
	const struct ref *tag_ref;
	struct ref *rm = NULL;
	const struct ref *ref;

	for_each_ref(add_existing, &existing_refs);
	for (ref = transport_get_remote_refs(transport); ref; ref = ref->next) {
		if (prefixcmp(ref->name, "refs/tags"))
			continue;

		ref_name = xstrdup(ref->name);
		ref_name_len = strlen(ref_name);
		ref_sha1 = ref->old_sha1;

		if (!strcmp(ref_name + ref_name_len - 3, "^{}")) {
			ref_name[ref_name_len - 3] = 0;
			tag_ref = transport_get_remote_refs(transport);
			while (tag_ref) {
				if (!strcmp(tag_ref->name, ref_name)) {
					ref_sha1 = tag_ref->old_sha1;
					break;
				}
				tag_ref = tag_ref->next;
			}
		}

		if (!path_list_has_path(&existing_refs, ref_name) &&
		    !path_list_has_path(&new_refs, ref_name) &&
		    (has_sha1_file(ref->old_sha1) ||
		     will_fetch(head, ref->old_sha1))) {
			path_list_insert(ref_name, &new_refs);

			rm = alloc_ref(strlen(ref_name) + 1);
			strcpy(rm->name, ref_name);
			rm->peer_ref = alloc_ref(strlen(ref_name) + 1);
			strcpy(rm->peer_ref->name, ref_name);
			hashcpy(rm->old_sha1, ref_sha1);

			**tail = rm;
			*tail = &rm->next;
		}
		free(ref_name);
	}
	path_list_clear(&existing_refs, 0);
	path_list_clear(&new_refs, 0);
}

static int do_fetch(struct transport *transport,
		    struct refspec *refs, int ref_count)
{
	struct ref *ref_map;
	struct ref *rm;
	int autotags = (transport->remote->fetch_tags == 1);
	if (transport->remote->fetch_tags == 2 && tags != TAGS_UNSET)
		tags = TAGS_SET;
	if (transport->remote->fetch_tags == -1)
		tags = TAGS_UNSET;

	if (!transport->get_refs_list || !transport->fetch)
		die("Don't know how to fetch from %s", transport->url);

	/* if not appending, truncate FETCH_HEAD */
	if (!append) {
		char *filename = git_path("FETCH_HEAD");
		FILE *fp = fopen(filename, "w");
		if (!fp)
			return error("cannot open %s: %s\n", filename, strerror(errno));
		fclose(fp);
	}

	ref_map = get_ref_map(transport, refs, ref_count, tags, &autotags);

	for (rm = ref_map; rm; rm = rm->next) {
		if (rm->peer_ref)
			read_ref(rm->peer_ref->name, rm->peer_ref->old_sha1);
	}

	if (tags == TAGS_DEFAULT && autotags)
		transport_set_option(transport, TRANS_OPT_FOLLOWTAGS, "1");
	if (fetch_refs(transport, ref_map)) {
		free_refs(ref_map);
		return 1;
	}
	free_refs(ref_map);

	/* if neither --no-tags nor --tags was specified, do automated tag
	 * following ... */
	if (tags == TAGS_DEFAULT && autotags) {
		struct ref **tail = &ref_map;
		ref_map = NULL;
		find_non_local_tags(transport, &ref_map, &tail);
		if (ref_map) {
			transport_set_option(transport, TRANS_OPT_FOLLOWTAGS, NULL);
			transport_set_option(transport, TRANS_OPT_DEPTH, "0");
			fetch_refs(transport, ref_map);
		}
		free_refs(ref_map);
	}

	transport_disconnect(transport);

	return 0;
}

static void set_option(const char *name, const char *value)
{
	int r = transport_set_option(transport, name, value);
	if (r < 0)
		die("Option \"%s\" value \"%s\" is not valid for %s\n",
			name, value, transport->url);
	if (r > 0)
		warning("Option \"%s\" is ignored for %s\n",
			name, transport->url);
}

int cmd_fetch(int argc, const char **argv, const char *prefix)
{
	struct remote *remote;
	int i;
	static const char **refs = NULL;
	int ref_nr = 0;

	/* Record the command line for the reflog */
	strbuf_addstr(&default_rla, "fetch");
	for (i = 1; i < argc; i++)
		strbuf_addf(&default_rla, " %s", argv[i]);

	argc = parse_options(argc, argv,
			     builtin_fetch_options, builtin_fetch_usage, 0);

	if (argc == 0)
		remote = remote_get(NULL);
	else
		remote = remote_get(argv[0]);

	transport = transport_get(remote, remote->url[0]);
	if (verbose >= 2)
		transport->verbose = 1;
	if (quiet)
		transport->verbose = -1;
	if (upload_pack)
		set_option(TRANS_OPT_UPLOADPACK, upload_pack);
	if (keep)
		set_option(TRANS_OPT_KEEP, "yes");
	if (depth)
		set_option(TRANS_OPT_DEPTH, depth);

	if (!transport->url)
		die("Where do you want to fetch from today?");

	if (argc > 1) {
		int j = 0;
		refs = xcalloc(argc + 1, sizeof(const char *));
		for (i = 1; i < argc; i++) {
			if (!strcmp(argv[i], "tag")) {
				char *ref;
				i++;
				if (i >= argc)
					die("You need to specify a tag name.");
				ref = xmalloc(strlen(argv[i]) * 2 + 22);
				strcpy(ref, "refs/tags/");
				strcat(ref, argv[i]);
				strcat(ref, ":refs/tags/");
				strcat(ref, argv[i]);
				refs[j++] = ref;
			} else
				refs[j++] = argv[i];
		}
		refs[j] = NULL;
		ref_nr = j;
	}

	signal(SIGINT, unlock_pack_on_signal);
	atexit(unlock_pack);
	return do_fetch(transport,
			parse_fetch_refspec(ref_nr, refs), ref_nr);
}
Commit	Line	Data
b888d61c DB	1	/*
	2	* "git fetch"
	3	*/
	4	#include "cache.h"
	5	#include "refs.h"
	6	#include "commit.h"
	7	#include "builtin.h"
	8	#include "path-list.h"
	9	#include "remote.h"
	10	#include "transport.h"
4191c356	11	#include "run-command.h"
83201998	12	#include "parse-options.h"
b888d61c	13
83201998 KH	14	static const char * const builtin_fetch_usage[] = {
	15	"git-fetch [options] [<repository> <refspec>...]",
	16	NULL
	17	};
b888d61c	18
83201998 KH	19	enum {
	20	TAGS_UNSET = 0,
	21	TAGS_DEFAULT = 1,
	22	TAGS_SET = 2
	23	};
	24
	25	static int append, force, keep, update_head_ok, verbose, quiet;
	26	static int tags = TAGS_DEFAULT;
4191c356	27	static const char *depth;
83201998	28	static const char *upload_pack;
2d324efa	29	static struct strbuf default_rla = STRBUF_INIT;
e4022ed2 SP	30	static struct transport *transport;
e4022ed2 SP	31
83201998 KH	32	static struct option builtin_fetch_options[] = {
	33	OPT__QUIET(&quiet),
	34	OPT__VERBOSE(&verbose),
	35	OPT_BOOLEAN('a', "append", &append,
	36	"append to .git/FETCH_HEAD instead of overwriting"),
	37	OPT_STRING(0, "upload-pack", &upload_pack, "PATH",
	38	"path to upload pack on remote end"),
	39	OPT_BOOLEAN('f', "force", &force,
	40	"force overwrite of local branch"),
	41	OPT_SET_INT('t', "tags", &tags,
	42	"fetch all tags and associated objects", TAGS_SET),
e7951290 JS	43	OPT_SET_INT('n', NULL, &tags,
e7951290 JS	44	"do not fetch all tags (--no-tags)", TAGS_UNSET),
83201998 KH	45	OPT_BOOLEAN('k', "keep", &keep, "keep downloaded pack"),
	46	OPT_BOOLEAN('u', "update-head-ok", &update_head_ok,
	47	"allow updating of HEAD ref"),
	48	OPT_STRING(0, "depth", &depth, "DEPTH",
	49	"deepen history of shallow clone"),
	50	OPT_END()
	51	};
	52
e4022ed2 SP	53	static void unlock_pack(void)
	54	{
	55	if (transport)
	56	transport_unlock_pack(transport);
	57	}
	58
	59	static void unlock_pack_on_signal(int signo)
	60	{
	61	unlock_pack();
	62	signal(SIGINT, SIG_DFL);
	63	raise(signo);
	64	}
b888d61c	65
85682c19	66	static void add_merge_config(struct ref **head,
4577370e	67	const struct ref *remote_refs,
85682c19 SP	68	struct branch *branch,
85682c19 SP	69	struct ref ***tail)
b888d61c	70	{
85682c19	71	int i;
b888d61c	72
85682c19 SP	73	for (i = 0; i < branch->merge_nr; i++) {
	74	struct ref rm, old_tail = tail;
	75	struct refspec refspec;
	76
	77	for (rm = *head; rm; rm = rm->next) {
	78	if (branch_merge_matches(branch, i, rm->name)) {
b888d61c	79	rm->merge = 1;
85682c19 SP	80	break;
85682c19 SP	81	}
b888d61c	82	}
85682c19 SP	83	if (rm)
	84	continue;
	85
9ad7c5ae JH	86	/*
9ad7c5ae JH	87	* Not fetched to a tracking branch? We need to fetch
85682c19	88	* it anyway to allow this branch's "branch.$name.merge"
9ad7c5ae JH	89	* to be honored by git-pull, but we do not have to
	90	* fail if branch.$name.merge is misconfigured to point
	91	* at a nonexisting branch. If we were indeed called by
	92	* git-pull, it will notice the misconfiguration because
	93	* there is no entry in the resulting FETCH_HEAD marked
	94	* for merging.
85682c19 SP	95	*/
	96	refspec.src = branch->merge[i]->src;
	97	refspec.dst = NULL;
	98	refspec.pattern = 0;
	99	refspec.force = 0;
9ad7c5ae	100	get_fetch_map(remote_refs, &refspec, tail, 1);
85682c19 SP	101	for (rm = *old_tail; rm; rm = rm->next)
85682c19 SP	102	rm->merge = 1;
b888d61c DB	103	}
	104	}
	105
767f176a SP	106	static void find_non_local_tags(struct transport *transport,
	107	struct ref **head,
	108	struct ref ***tail);
	109
b888d61c DB	110	static struct ref get_ref_map(struct transport transport,
	111	struct refspec *refs, int ref_count, int tags,
	112	int *autotags)
	113	{
	114	int i;
	115	struct ref *rm;
	116	struct ref *ref_map = NULL;
	117	struct ref **tail = &ref_map;
	118
4577370e	119	const struct ref *remote_refs = transport_get_remote_refs(transport);
b888d61c	120
83201998	121	if (ref_count \|\| tags == TAGS_SET) {
b888d61c	122	for (i = 0; i < ref_count; i++) {
9ad7c5ae	123	get_fetch_map(remote_refs, &refs[i], &tail, 0);
b888d61c DB	124	if (refs[i].dst && refs[i].dst[0])
	125	*autotags = 1;
	126	}
	127	/* Merge everything on the command line, but not --tags */
	128	for (rm = ref_map; rm; rm = rm->next)
	129	rm->merge = 1;
83201998	130	if (tags == TAGS_SET) {
b888d61c DB	131	struct refspec refspec;
	132	refspec.src = "refs/tags/";
	133	refspec.dst = "refs/tags/";
	134	refspec.pattern = 1;
	135	refspec.force = 0;
9ad7c5ae	136	get_fetch_map(remote_refs, &refspec, &tail, 0);
b888d61c DB	137	}
	138	} else {
	139	/* Use the defaults */
	140	struct remote *remote = transport->remote;
85682c19 SP	141	struct branch *branch = branch_get(NULL);
	142	int has_merge = branch_has_merge_config(branch);
	143	if (remote && (remote->fetch_refspec_nr \|\| has_merge)) {
b888d61c	144	for (i = 0; i < remote->fetch_refspec_nr; i++) {
9ad7c5ae	145	get_fetch_map(remote_refs, &remote->fetch[i], &tail, 0);
b888d61c DB	146	if (remote->fetch[i].dst &&
	147	remote->fetch[i].dst[0])
	148	*autotags = 1;
85682c19	149	if (!i && !has_merge && ref_map &&
cfb8f898	150	!remote->fetch[0].pattern)
85682c19	151	ref_map->merge = 1;
b888d61c	152	}
da0204df JS	153	/*
	154	* if the remote we're fetching from is the same
	155	* as given in branch.<name>.remote, we add the
	156	* ref given in branch.<name>.merge, too.
	157	*/
9ad7c5ae JH	158	if (has_merge &&
9ad7c5ae JH	159	!strcmp(branch->remote_name, remote->name))
85682c19	160	add_merge_config(&ref_map, remote_refs, branch, &tail);
b888d61c DB	161	} else {
b888d61c DB	162	ref_map = get_remote_ref(remote_refs, "HEAD");
9ad7c5ae JH	163	if (!ref_map)
9ad7c5ae JH	164	die("Couldn't find remote ref HEAD");
b888d61c	165	ref_map->merge = 1;
5aaf7f2a	166	tail = &ref_map->next;
b888d61c DB	167	}
b888d61c DB	168	}
767f176a SP	169	if (tags == TAGS_DEFAULT && *autotags)
767f176a SP	170	find_non_local_tags(transport, &ref_map, &tail);
2467a4fa	171	ref_remove_duplicates(ref_map);
b888d61c DB	172
	173	return ref_map;
	174	}
	175
b888d61c DB	176	static int s_update_ref(const char *action,
	177	struct ref *ref,
	178	int check_old)
	179	{
	180	char msg[1024];
	181	char *rla = getenv("GIT_REFLOG_ACTION");
	182	static struct ref_lock *lock;
	183
	184	if (!rla)
2d324efa	185	rla = default_rla.buf;
b888d61c DB	186	snprintf(msg, sizeof(msg), "%s: %s", rla, action);
	187	lock = lock_any_ref_for_update(ref->name,
	188	check_old ? ref->old_sha1 : NULL, 0);
	189	if (!lock)
	190	return 1;
	191	if (write_ref_sha1(lock, ref->new_sha1, msg) < 0)
	192	return 1;
	193	return 0;
	194	}
	195
165f3902	196	#define SUMMARY_WIDTH (2 * DEFAULT_ABBREV + 3)
9ef4272b	197	#define REFCOL_WIDTH 10
165f3902	198
b888d61c	199	static int update_local_ref(struct ref *ref,
165f3902 NP	200	const char *remote,
	201	int verbose,
	202	char *display)
b888d61c	203	{
b888d61c DB	204	struct commit current = NULL, updated;
	205	enum object_type type;
	206	struct branch *current_branch = branch_get(NULL);
165f3902 NP	207	const char *pretty_ref = ref->name + (
	208	!prefixcmp(ref->name, "refs/heads/") ? 11 :
	209	!prefixcmp(ref->name, "refs/tags/") ? 10 :
	210	!prefixcmp(ref->name, "refs/remotes/") ? 13 :
	211	0);
b888d61c	212
165f3902	213	*display = 0;
b888d61c DB	214	type = sha1_object_info(ref->new_sha1, NULL);
	215	if (type < 0)
	216	die("object %s not found", sha1_to_hex(ref->new_sha1));
	217
	218	if (!*ref->name) {
	219	/* Not storing */
165f3902 NP	220	if (verbose)
165f3902 NP	221	sprintf(display, "* branch %s -> FETCH_HEAD", remote);
b888d61c DB	222	return 0;
	223	}
	224
	225	if (!hashcmp(ref->old_sha1, ref->new_sha1)) {
165f3902	226	if (verbose)
9ef4272b PH	227	sprintf(display, "= %-s %-s -> %s", SUMMARY_WIDTH,
	228	"[up to date]", REFCOL_WIDTH, remote,
	229	pretty_ref);
b888d61c DB	230	return 0;
	231	}
	232
b3abdd9d SP	233	if (current_branch &&
b3abdd9d SP	234	!strcmp(ref->name, current_branch->name) &&
b888d61c DB	235	!(update_head_ok \|\| is_bare_repository()) &&
	236	!is_null_sha1(ref->old_sha1)) {
	237	/*
	238	* If this is the head, and it's not okay to update
	239	* the head, and the old value of the head isn't empty...
	240	*/
9ef4272b PH	241	sprintf(display, "! %-s %-s -> %s (can't fetch in current branch)",
	242	SUMMARY_WIDTH, "[rejected]", REFCOL_WIDTH, remote,
	243	pretty_ref);
b888d61c DB	244	return 1;
	245	}
	246
	247	if (!is_null_sha1(ref->old_sha1) &&
	248	!prefixcmp(ref->name, "refs/tags/")) {
9ef4272b PH	249	sprintf(display, "- %-s %-s -> %s",
	250	SUMMARY_WIDTH, "[tag update]", REFCOL_WIDTH, remote,
	251	pretty_ref);
b888d61c DB	252	return s_update_ref("updating tag", ref, 0);
	253	}
	254
cfa5b2b7 SP	255	current = lookup_commit_reference_gently(ref->old_sha1, 1);
cfa5b2b7 SP	256	updated = lookup_commit_reference_gently(ref->new_sha1, 1);
b888d61c	257	if (!current \|\| !updated) {
165f3902 NP	258	const char *msg;
	259	const char *what;
	260	if (!strncmp(ref->name, "refs/tags/", 10)) {
b888d61c	261	msg = "storing tag";
165f3902 NP	262	what = "[new tag]";
	263	}
	264	else {
b888d61c	265	msg = "storing head";
165f3902 NP	266	what = "[new branch]";
	267	}
	268
9ef4272b PH	269	sprintf(display, "* %-s %-s -> %s", SUMMARY_WIDTH, what,
9ef4272b PH	270	REFCOL_WIDTH, remote, pretty_ref);
b888d61c DB	271	return s_update_ref(msg, ref, 0);
	272	}
	273
b888d61c	274	if (in_merge_bases(current, &updated, 1)) {
165f3902 NP	275	char quickref[83];
	276	strcpy(quickref, find_unique_abbrev(current->object.sha1, DEFAULT_ABBREV));
	277	strcat(quickref, "..");
	278	strcat(quickref, find_unique_abbrev(ref->new_sha1, DEFAULT_ABBREV));
9ef4272b PH	279	sprintf(display, " %-s %-s -> %s", SUMMARY_WIDTH, quickref,
9ef4272b PH	280	REFCOL_WIDTH, remote, pretty_ref);
b888d61c	281	return s_update_ref("fast forward", ref, 1);
165f3902 NP	282	} else if (force \|\| ref->force) {
	283	char quickref[84];
	284	strcpy(quickref, find_unique_abbrev(current->object.sha1, DEFAULT_ABBREV));
	285	strcat(quickref, "...");
	286	strcat(quickref, find_unique_abbrev(ref->new_sha1, DEFAULT_ABBREV));
9ef4272b PH	287	sprintf(display, "+ %-s %-s -> %s (forced update)",
9ef4272b PH	288	SUMMARY_WIDTH, quickref, REFCOL_WIDTH, remote, pretty_ref);
165f3902 NP	289	return s_update_ref("forced-update", ref, 1);
165f3902 NP	290	} else {
9ef4272b PH	291	sprintf(display, "! %-s %-s -> %s (non fast forward)",
	292	SUMMARY_WIDTH, "[rejected]", REFCOL_WIDTH, remote,
	293	pretty_ref);
b888d61c DB	294	return 1;
b888d61c DB	295	}
b888d61c DB	296	}
b888d61c DB	297
d6617c7c	298	static int store_updated_refs(const char url, struct ref ref_map)
b888d61c DB	299	{
	300	FILE *fp;
	301	struct commit *commit;
165f3902	302	int url_len, i, note_len, shown_url = 0;
b888d61c DB	303	char note[1024];
	304	const char what, kind;
	305	struct ref *rm;
d6617c7c	306	char *filename = git_path("FETCH_HEAD");
b888d61c	307
d6617c7c AGR	308	fp = fopen(filename, "a");
	309	if (!fp)
	310	return error("cannot open %s: %s\n", filename, strerror(errno));
b888d61c DB	311	for (rm = ref_map; rm; rm = rm->next) {
	312	struct ref *ref = NULL;
	313
	314	if (rm->peer_ref) {
	315	ref = xcalloc(1, sizeof(*ref) + strlen(rm->peer_ref->name) + 1);
	316	strcpy(ref->name, rm->peer_ref->name);
	317	hashcpy(ref->old_sha1, rm->peer_ref->old_sha1);
	318	hashcpy(ref->new_sha1, rm->old_sha1);
1aad91f5	319	ref->force = rm->peer_ref->force;
b888d61c DB	320	}
b888d61c DB	321
cfa5b2b7	322	commit = lookup_commit_reference_gently(rm->old_sha1, 1);
b888d61c DB	323	if (!commit)
	324	rm->merge = 0;
	325
	326	if (!strcmp(rm->name, "HEAD")) {
	327	kind = "";
	328	what = "";
	329	}
	330	else if (!prefixcmp(rm->name, "refs/heads/")) {
	331	kind = "branch";
	332	what = rm->name + 11;
	333	}
	334	else if (!prefixcmp(rm->name, "refs/tags/")) {
	335	kind = "tag";
	336	what = rm->name + 10;
	337	}
	338	else if (!prefixcmp(rm->name, "refs/remotes/")) {
	339	kind = "remote branch";
	340	what = rm->name + 13;
	341	}
	342	else {
	343	kind = "";
	344	what = rm->name;
	345	}
	346
	347	url_len = strlen(url);
	348	for (i = url_len - 1; url[i] == '/' && 0 <= i; i--)
	349	;
	350	url_len = i + 1;
	351	if (4 < i && !strncmp(".git", url + i - 3, 4))
	352	url_len = i - 3;
	353
	354	note_len = 0;
	355	if (*what) {
	356	if (*kind)
	357	note_len += sprintf(note + note_len, "%s ",
	358	kind);
	359	note_len += sprintf(note + note_len, "'%s' of ", what);
	360	}
	361	note_len += sprintf(note + note_len, "%.*s", url_len, url);
	362	fprintf(fp, "%s\t%s\t%s\n",
	363	sha1_to_hex(commit ? commit->object.sha1 :
	364	rm->old_sha1),
	365	rm->merge ? "" : "not-for-merge",
	366	note);
	367
165f3902 NP	368	if (ref) {
	369	update_local_ref(ref, what, verbose, note);
	370	if (*note) {
	371	if (!shown_url) {
	372	fprintf(stderr, "From %.*s\n",
	373	url_len, url);
	374	shown_url = 1;
	375	}
	376	fprintf(stderr, " %s\n", note);
	377	}
	378	}
b888d61c DB	379	}
b888d61c DB	380	fclose(fp);
d6617c7c	381	return 0;
b888d61c DB	382	}
b888d61c DB	383
4191c356 SP	384	/*
	385	* We would want to bypass the object transfer altogether if
	386	* everything we are going to fetch already exists and connected
	387	* locally.
	388	*
	389	* The refs we are going to fetch are in to_fetch (nr_heads in
	390	* total). If running
	391	*
	392	* $ git-rev-list --objects to_fetch[0] to_fetch[1] ... --not --all
	393	*
	394	* does not error out, that means everything reachable from the
	395	* refs we are going to fetch exists and is connected to some of
	396	* our existing refs.
	397	*/
	398	static int quickfetch(struct ref *ref_map)
	399	{
	400	struct child_process revlist;
	401	struct ref *ref;
	402	char **argv;
	403	int i, err;
	404
	405	/*
	406	* If we are deepening a shallow clone we already have these
	407	* objects reachable. Running rev-list here will return with
	408	* a good (0) exit status and we'll bypass the fetch that we
	409	* really need to perform. Claiming failure now will ensure
	410	* we perform the network exchange to deepen our history.
	411	*/
	412	if (depth)
	413	return -1;
	414
	415	for (i = 0, ref = ref_map; ref; ref = ref->next)
	416	i++;
	417	if (!i)
	418	return 0;
	419
	420	argv = xmalloc(sizeof(argv) (i + 6));
	421	i = 0;
	422	argv[i++] = xstrdup("rev-list");
	423	argv[i++] = xstrdup("--quiet");
	424	argv[i++] = xstrdup("--objects");
	425	for (ref = ref_map; ref; ref = ref->next)
	426	argv[i++] = xstrdup(sha1_to_hex(ref->old_sha1));
	427	argv[i++] = xstrdup("--not");
	428	argv[i++] = xstrdup("--all");
	429	argv[i++] = NULL;
	430
	431	memset(&revlist, 0, sizeof(revlist));
	432	revlist.argv = (const char**)argv;
	433	revlist.git_cmd = 1;
	434	revlist.no_stdin = 1;
	435	revlist.no_stdout = 1;
	436	revlist.no_stderr = 1;
	437	err = run_command(&revlist);
	438
	439	for (i = 0; argv[i]; i++)
	440	free(argv[i]);
	441	free(argv);
	442	return err;
	443	}
	444
b888d61c DB	445	static int fetch_refs(struct transport transport, struct ref ref_map)
b888d61c DB	446	{
4191c356 SP	447	int ret = quickfetch(ref_map);
	448	if (ret)
	449	ret = transport_fetch_refs(transport, ref_map);
b888d61c	450	if (!ret)
d6617c7c	451	ret \|= store_updated_refs(transport->url, ref_map);
1788c39c	452	transport_unlock_pack(transport);
b888d61c DB	453	return ret;
	454	}
	455
	456	static int add_existing(const char refname, const unsigned char sha1,
	457	int flag, void *cbdata)
	458	{
	459	struct path_list list = (struct path_list )cbdata;
	460	path_list_insert(refname, list);
	461	return 0;
	462	}
	463
cf7f929a SP	464	static int will_fetch(struct ref *head, const unsigned char sha1)
	465	{
	466	struct ref rm = head;
	467	while (rm) {
	468	if (!hashcmp(rm->old_sha1, sha1))
	469	return 1;
	470	rm = rm->next;
	471	}
	472	return 0;
	473	}
	474
c50b2b47 SP	475	static void find_non_local_tags(struct transport *transport,
	476	struct ref **head,
	477	struct ref ***tail)
b888d61c	478	{
49d58fd0	479	struct path_list existing_refs = { NULL, 0, 0, 0 };
b888d61c DB	480	struct path_list new_refs = { NULL, 0, 0, 1 };
	481	char *ref_name;
	482	int ref_name_len;
4577370e DB	483	const unsigned char *ref_sha1;
4577370e DB	484	const struct ref *tag_ref;
b888d61c	485	struct ref *rm = NULL;
4577370e	486	const struct ref *ref;
b888d61c DB	487
	488	for_each_ref(add_existing, &existing_refs);
	489	for (ref = transport_get_remote_refs(transport); ref; ref = ref->next) {
	490	if (prefixcmp(ref->name, "refs/tags"))
	491	continue;
	492
	493	ref_name = xstrdup(ref->name);
	494	ref_name_len = strlen(ref_name);
	495	ref_sha1 = ref->old_sha1;
	496
	497	if (!strcmp(ref_name + ref_name_len - 3, "^{}")) {
	498	ref_name[ref_name_len - 3] = 0;
	499	tag_ref = transport_get_remote_refs(transport);
	500	while (tag_ref) {
	501	if (!strcmp(tag_ref->name, ref_name)) {
	502	ref_sha1 = tag_ref->old_sha1;
	503	break;
	504	}
	505	tag_ref = tag_ref->next;
	506	}
	507	}
	508
	509	if (!path_list_has_path(&existing_refs, ref_name) &&
	510	!path_list_has_path(&new_refs, ref_name) &&
cf7f929a SP	511	(has_sha1_file(ref->old_sha1) \|\|
cf7f929a SP	512	will_fetch(head, ref->old_sha1))) {
b888d61c DB	513	path_list_insert(ref_name, &new_refs);
	514
	515	rm = alloc_ref(strlen(ref_name) + 1);
	516	strcpy(rm->name, ref_name);
	517	rm->peer_ref = alloc_ref(strlen(ref_name) + 1);
	518	strcpy(rm->peer_ref->name, ref_name);
	519	hashcpy(rm->old_sha1, ref_sha1);
	520
c50b2b47 SP	521	**tail = rm;
c50b2b47 SP	522	*tail = &rm->next;
b888d61c DB	523	}
	524	free(ref_name);
	525	}
49d58fd0 SP	526	path_list_clear(&existing_refs, 0);
49d58fd0 SP	527	path_list_clear(&new_refs, 0);
b888d61c DB	528	}
	529
	530	static int do_fetch(struct transport *transport,
	531	struct refspec *refs, int ref_count)
	532	{
7f98428d	533	struct ref *ref_map;
b888d61c DB	534	struct ref *rm;
b888d61c DB	535	int autotags = (transport->remote->fetch_tags == 1);
83201998 KH	536	if (transport->remote->fetch_tags == 2 && tags != TAGS_UNSET)
83201998 KH	537	tags = TAGS_SET;
b888d61c	538	if (transport->remote->fetch_tags == -1)
83201998	539	tags = TAGS_UNSET;
b888d61c	540
824d5776	541	if (!transport->get_refs_list \|\| !transport->fetch)
b888d61c DB	542	die("Don't know how to fetch from %s", transport->url);
	543
	544	/* if not appending, truncate FETCH_HEAD */
d6617c7c AGR	545	if (!append) {
	546	char *filename = git_path("FETCH_HEAD");
	547	FILE *fp = fopen(filename, "w");
	548	if (!fp)
	549	return error("cannot open %s: %s\n", filename, strerror(errno));
	550	fclose(fp);
	551	}
b888d61c DB	552
	553	ref_map = get_ref_map(transport, refs, ref_count, tags, &autotags);
	554
	555	for (rm = ref_map; rm; rm = rm->next) {
	556	if (rm->peer_ref)
	557	read_ref(rm->peer_ref->name, rm->peer_ref->old_sha1);
b888d61c DB	558	}
b888d61c DB	559
41fa7d2e SP	560	if (tags == TAGS_DEFAULT && autotags)
41fa7d2e SP	561	transport_set_option(transport, TRANS_OPT_FOLLOWTAGS, "1");
b888d61c DB	562	if (fetch_refs(transport, ref_map)) {
	563	free_refs(ref_map);
	564	return 1;
	565	}
7f98428d	566	free_refs(ref_map);
b888d61c DB	567
	568	/* if neither --no-tags nor --tags was specified, do automated tag
	569	* following ... */
83201998	570	if (tags == TAGS_DEFAULT && autotags) {
c50b2b47 SP	571	struct ref **tail = &ref_map;
	572	ref_map = NULL;
	573	find_non_local_tags(transport, &ref_map, &tail);
b888d61c	574	if (ref_map) {
41fa7d2e	575	transport_set_option(transport, TRANS_OPT_FOLLOWTAGS, NULL);
b888d61c DB	576	transport_set_option(transport, TRANS_OPT_DEPTH, "0");
	577	fetch_refs(transport, ref_map);
	578	}
	579	free_refs(ref_map);
	580	}
	581
ba227857 DB	582	transport_disconnect(transport);
ba227857 DB	583
b888d61c DB	584	return 0;
	585	}
	586
ab865e6e SP	587	static void set_option(const char name, const char value)
	588	{
	589	int r = transport_set_option(transport, name, value);
	590	if (r < 0)
	591	die("Option \"%s\" value \"%s\" is not valid for %s\n",
	592	name, value, transport->url);
	593	if (r > 0)
	594	warning("Option \"%s\" is ignored for %s\n",
	595	name, transport->url);
	596	}
	597
b888d61c DB	598	int cmd_fetch(int argc, const char *argv, const char prefix)
	599	{
	600	struct remote *remote;
2d324efa	601	int i;
b888d61c DB	602	static const char **refs = NULL;
b888d61c DB	603	int ref_nr = 0;
b888d61c	604
2d324efa KH	605	/* Record the command line for the reflog */
	606	strbuf_addstr(&default_rla, "fetch");
	607	for (i = 1; i < argc; i++)
	608	strbuf_addf(&default_rla, " %s", argv[i]);
	609
83201998 KH	610	argc = parse_options(argc, argv,
83201998 KH	611	builtin_fetch_options, builtin_fetch_usage, 0);
b888d61c	612
83201998	613	if (argc == 0)
b888d61c DB	614	remote = remote_get(NULL);
b888d61c DB	615	else
83201998	616	remote = remote_get(argv[0]);
b888d61c	617
28b91f8a	618	transport = transport_get(remote, remote->url[0]);
b888d61c DB	619	if (verbose >= 2)
	620	transport->verbose = 1;
	621	if (quiet)
2b5a06ed	622	transport->verbose = -1;
b888d61c	623	if (upload_pack)
ab865e6e	624	set_option(TRANS_OPT_UPLOADPACK, upload_pack);
b888d61c	625	if (keep)
ab865e6e SP	626	set_option(TRANS_OPT_KEEP, "yes");
	627	if (depth)
	628	set_option(TRANS_OPT_DEPTH, depth);
b888d61c DB	629
	630	if (!transport->url)
	631	die("Where do you want to fetch from today?");
	632
83201998	633	if (argc > 1) {
b888d61c	634	int j = 0;
83201998 KH	635	refs = xcalloc(argc + 1, sizeof(const char *));
83201998 KH	636	for (i = 1; i < argc; i++) {
b888d61c DB	637	if (!strcmp(argv[i], "tag")) {
	638	char *ref;
	639	i++;
f53423b0 KB	640	if (i >= argc)
f53423b0 KB	641	die("You need to specify a tag name.");
b888d61c DB	642	ref = xmalloc(strlen(argv[i]) * 2 + 22);
	643	strcpy(ref, "refs/tags/");
	644	strcat(ref, argv[i]);
	645	strcat(ref, ":refs/tags/");
	646	strcat(ref, argv[i]);
	647	refs[j++] = ref;
	648	} else
	649	refs[j++] = argv[i];
b888d61c DB	650	}
	651	refs[j] = NULL;
	652	ref_nr = j;
b888d61c DB	653	}
b888d61c DB	654
e4022ed2 SP	655	signal(SIGINT, unlock_pack_on_signal);
e4022ed2 SP	656	atexit(unlock_pack);
46220ca1 JH	657	return do_fetch(transport,
46220ca1 JH	658	parse_fetch_refspec(ref_nr, refs), ref_nr);
b888d61c	659	}