[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_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 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;
		}
	}
	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 struct ref *find_non_local_tags(struct transport *transport)
{
	static 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;
	struct ref *ref_map = NULL;
	struct ref **tail = &ref_map;
	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)) {
			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);
	}

	return ref_map;
}

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