remote.c 42.0 KB
Newer Older
1 2 3
#include "cache.h"
#include "remote.h"
#include "refs.h"
4 5 6
#include "commit.h"
#include "diff.h"
#include "revision.h"
7
#include "dir.h"
8
#include "tag.h"
9
#include "string-list.h"
10

F
Felipe Contreras 已提交
11 12
enum map_direction { FROM_SRC, FROM_DST };

13 14 15
static struct refspec s_tag_refspec = {
	0,
	1,
J
Junio C Hamano 已提交
16
	0,
D
Daniel Barkalow 已提交
17 18
	"refs/tags/*",
	"refs/tags/*"
19 20 21 22
};

const struct refspec *tag_refspec = &s_tag_refspec;

23 24 25 26
struct counted_string {
	size_t len;
	const char *s;
};
27 28
struct rewrite {
	const char *base;
29 30
	size_t baselen;
	struct counted_string *instead_of;
31 32 33
	int instead_of_nr;
	int instead_of_alloc;
};
34 35 36 37 38
struct rewrites {
	struct rewrite **rewrite;
	int rewrite_alloc;
	int rewrite_nr;
};
39

40
static struct remote **remotes;
D
Daniel Barkalow 已提交
41 42
static int remotes_alloc;
static int remotes_nr;
43

44
static struct branch **branches;
D
Daniel Barkalow 已提交
45 46
static int branches_alloc;
static int branches_nr;
47 48 49

static struct branch *current_branch;
static const char *default_remote_name;
50
static int explicit_default_remote_name;
51

52
static struct rewrites rewrites;
53
static struct rewrites rewrites_push;
54

55 56 57
#define BUF_SIZE (2048)
static char buffer[BUF_SIZE];

58 59
static int valid_remote(const struct remote *remote)
{
60
	return (!!remote->url) || (!!remote->foreign_vcs);
61 62
}

63
static const char *alias_url(const char *url, struct rewrites *r)
64 65
{
	int i, j;
66 67 68 69 70 71
	char *ret;
	struct counted_string *longest;
	int longest_i;

	longest = NULL;
	longest_i = -1;
72 73
	for (i = 0; i < r->rewrite_nr; i++) {
		if (!r->rewrite[i])
74
			continue;
75 76
		for (j = 0; j < r->rewrite[i]->instead_of_nr; j++) {
			if (!prefixcmp(url, r->rewrite[i]->instead_of[j].s) &&
77
			    (!longest ||
78 79
			     longest->len < r->rewrite[i]->instead_of[j].len)) {
				longest = &(r->rewrite[i]->instead_of[j]);
80
				longest_i = i;
81 82 83
			}
		}
	}
84 85 86
	if (!longest)
		return url;

87
	ret = xmalloc(r->rewrite[longest_i]->baselen +
88
		     (strlen(url) - longest->len) + 1);
89 90
	strcpy(ret, r->rewrite[longest_i]->base);
	strcpy(ret + r->rewrite[longest_i]->baselen, url + longest->len);
91
	return ret;
92 93
}

94 95
static void add_push_refspec(struct remote *remote, const char *ref)
{
D
Daniel Barkalow 已提交
96 97 98 99
	ALLOC_GROW(remote->push_refspec,
		   remote->push_refspec_nr + 1,
		   remote->push_refspec_alloc);
	remote->push_refspec[remote->push_refspec_nr++] = ref;
100 101
}

102 103
static void add_fetch_refspec(struct remote *remote, const char *ref)
{
D
Daniel Barkalow 已提交
104 105 106 107
	ALLOC_GROW(remote->fetch_refspec,
		   remote->fetch_refspec_nr + 1,
		   remote->fetch_refspec_alloc);
	remote->fetch_refspec[remote->fetch_refspec_nr++] = ref;
108 109
}

110
static void add_url(struct remote *remote, const char *url)
111
{
D
Daniel Barkalow 已提交
112 113
	ALLOC_GROW(remote->url, remote->url_nr + 1, remote->url_alloc);
	remote->url[remote->url_nr++] = url;
114 115
}

116 117 118 119 120 121
static void add_pushurl(struct remote *remote, const char *pushurl)
{
	ALLOC_GROW(remote->pushurl, remote->pushurl_nr + 1, remote->pushurl_alloc);
	remote->pushurl[remote->pushurl_nr++] = pushurl;
}

122 123 124 125 126 127 128 129 130 131 132 133 134
static void add_pushurl_alias(struct remote *remote, const char *url)
{
	const char *pushurl = alias_url(url, &rewrites_push);
	if (pushurl != url)
		add_pushurl(remote, pushurl);
}

static void add_url_alias(struct remote *remote, const char *url)
{
	add_url(remote, alias_url(url, &rewrites));
	add_pushurl_alias(remote, url);
}

135 136
static struct remote *make_remote(const char *name, int len)
{
D
Daniel Barkalow 已提交
137 138
	struct remote *ret;
	int i;
139

D
Daniel Barkalow 已提交
140 141 142 143 144
	for (i = 0; i < remotes_nr; i++) {
		if (len ? (!strncmp(name, remotes[i]->name, len) &&
			   !remotes[i]->name[len]) :
		    !strcmp(name, remotes[i]->name))
			return remotes[i];
145 146
	}

D
Daniel Barkalow 已提交
147 148 149
	ret = xcalloc(1, sizeof(struct remote));
	ALLOC_GROW(remotes, remotes_nr + 1, remotes_alloc);
	remotes[remotes_nr++] = ret;
150
	if (len)
D
Daniel Barkalow 已提交
151
		ret->name = xstrndup(name, len);
152
	else
D
Daniel Barkalow 已提交
153 154
		ret->name = xstrdup(name);
	return ret;
155 156
}

157 158
static void add_merge(struct branch *branch, const char *name)
{
D
Daniel Barkalow 已提交
159 160 161
	ALLOC_GROW(branch->merge_name, branch->merge_nr + 1,
		   branch->merge_alloc);
	branch->merge_name[branch->merge_nr++] = name;
162 163 164 165
}

static struct branch *make_branch(const char *name, int len)
{
D
Daniel Barkalow 已提交
166 167
	struct branch *ret;
	int i;
168 169
	char *refname;

D
Daniel Barkalow 已提交
170 171 172 173 174
	for (i = 0; i < branches_nr; i++) {
		if (len ? (!strncmp(name, branches[i]->name, len) &&
			   !branches[i]->name[len]) :
		    !strcmp(name, branches[i]->name))
			return branches[i];
175 176
	}

D
Daniel Barkalow 已提交
177 178 179
	ALLOC_GROW(branches, branches_nr + 1, branches_alloc);
	ret = xcalloc(1, sizeof(struct branch));
	branches[branches_nr++] = ret;
180
	if (len)
D
Daniel Barkalow 已提交
181
		ret->name = xstrndup(name, len);
182
	else
D
Daniel Barkalow 已提交
183
		ret->name = xstrdup(name);
184
	refname = xmalloc(strlen(name) + strlen("refs/heads/") + 1);
185
	strcpy(refname, "refs/heads/");
D
Daniel Barkalow 已提交
186 187
	strcpy(refname + strlen("refs/heads/"), ret->name);
	ret->refname = refname;
188

D
Daniel Barkalow 已提交
189
	return ret;
190 191
}

192
static struct rewrite *make_rewrite(struct rewrites *r, const char *base, int len)
193 194 195 196
{
	struct rewrite *ret;
	int i;

197
	for (i = 0; i < r->rewrite_nr; i++) {
198
		if (len
199 200 201 202
		    ? (len == r->rewrite[i]->baselen &&
		       !strncmp(base, r->rewrite[i]->base, len))
		    : !strcmp(base, r->rewrite[i]->base))
			return r->rewrite[i];
203 204
	}

205
	ALLOC_GROW(r->rewrite, r->rewrite_nr + 1, r->rewrite_alloc);
206
	ret = xcalloc(1, sizeof(struct rewrite));
207
	r->rewrite[r->rewrite_nr++] = ret;
208
	if (len) {
209
		ret->base = xstrndup(base, len);
210 211 212
		ret->baselen = len;
	}
	else {
213
		ret->base = xstrdup(base);
214 215
		ret->baselen = strlen(base);
	}
216 217 218 219 220 221
	return ret;
}

static void add_instead_of(struct rewrite *rewrite, const char *instead_of)
{
	ALLOC_GROW(rewrite->instead_of, rewrite->instead_of_nr + 1, rewrite->instead_of_alloc);
222 223 224
	rewrite->instead_of[rewrite->instead_of_nr].s = instead_of;
	rewrite->instead_of[rewrite->instead_of_nr].len = strlen(instead_of);
	rewrite->instead_of_nr++;
225 226
}

227 228 229 230 231 232
static void read_remotes_file(struct remote *remote)
{
	FILE *f = fopen(git_path("remotes/%s", remote->name), "r");

	if (!f)
		return;
233
	remote->origin = REMOTE_REMOTES;
234 235 236 237 238 239 240 241 242 243
	while (fgets(buffer, BUF_SIZE, f)) {
		int value_list;
		char *s, *p;

		if (!prefixcmp(buffer, "URL:")) {
			value_list = 0;
			s = buffer + 4;
		} else if (!prefixcmp(buffer, "Push:")) {
			value_list = 1;
			s = buffer + 5;
244 245 246
		} else if (!prefixcmp(buffer, "Pull:")) {
			value_list = 2;
			s = buffer + 5;
247 248 249 250 251 252 253 254 255 256 257 258 259 260
		} else
			continue;

		while (isspace(*s))
			s++;
		if (!*s)
			continue;

		p = s + strlen(s);
		while (isspace(p[-1]))
			*--p = 0;

		switch (value_list) {
		case 0:
261
			add_url_alias(remote, xstrdup(s));
262 263 264 265
			break;
		case 1:
			add_push_refspec(remote, xstrdup(s));
			break;
266 267 268
		case 2:
			add_fetch_refspec(remote, xstrdup(s));
			break;
269 270 271 272 273 274 275 276
		}
	}
	fclose(f);
}

static void read_branches_file(struct remote *remote)
{
	const char *slash = strchr(remote->name, '/');
277
	char *frag;
278
	struct strbuf branch = STRBUF_INIT;
279 280 281 282 283 284 285 286 287 288 289 290 291 292 293
	int n = slash ? slash - remote->name : 1000;
	FILE *f = fopen(git_path("branches/%.*s", n, remote->name), "r");
	char *s, *p;
	int len;

	if (!f)
		return;
	s = fgets(buffer, BUF_SIZE, f);
	fclose(f);
	if (!s)
		return;
	while (isspace(*s))
		s++;
	if (!*s)
		return;
294
	remote->origin = REMOTE_BRANCHES;
295 296 297 298 299 300 301 302 303 304
	p = s + strlen(s);
	while (isspace(p[-1]))
		*--p = 0;
	len = p - s;
	if (slash)
		len += strlen(slash);
	p = xmalloc(len + 1);
	strcpy(p, s);
	if (slash)
		strcat(p, slash);
305 306 307 308 309 310 311 312 313 314 315 316

	/*
	 * With "slash", e.g. "git fetch jgarzik/netdev-2.6" when
	 * reading from $GIT_DIR/branches/jgarzik fetches "HEAD" from
	 * the partial URL obtained from the branches file plus
	 * "/netdev-2.6" and does not store it in any tracking ref.
	 * #branch specifier in the file is ignored.
	 *
	 * Otherwise, the branches file would have URL and optionally
	 * #branch specified.  The "master" (or specified) branch is
	 * fetched and stored in the local branch of the same name.
	 */
317 318 319
	frag = strchr(p, '#');
	if (frag) {
		*(frag++) = '\0';
320 321 322 323 324
		strbuf_addf(&branch, "refs/heads/%s", frag);
	} else
		strbuf_addstr(&branch, "refs/heads/master");
	if (!slash) {
		strbuf_addf(&branch, ":refs/heads/%s", remote->name);
325
	} else {
326 327
		strbuf_reset(&branch);
		strbuf_addstr(&branch, "HEAD:");
328
	}
329
	add_url_alias(remote, p);
330
	add_fetch_refspec(remote, strbuf_detach(&branch, NULL));
331 332 333 334 335 336 337 338 339 340
	/*
	 * Cogito compatible push: push current HEAD to remote #branch
	 * (master if missing)
	 */
	strbuf_init(&branch, 0);
	strbuf_addstr(&branch, "HEAD");
	if (frag)
		strbuf_addf(&branch, ":refs/heads/%s", frag);
	else
		strbuf_addstr(&branch, ":refs/heads/master");
341
	add_push_refspec(remote, strbuf_detach(&branch, NULL));
342
	remote->fetch_tags = 1; /* always auto-follow */
343 344
}

345
static int handle_config(const char *key, const char *value, void *cb)
346 347 348 349
{
	const char *name;
	const char *subkey;
	struct remote *remote;
350 351 352 353 354 355
	struct branch *branch;
	if (!prefixcmp(key, "branch.")) {
		name = key + 7;
		subkey = strrchr(name, '.');
		if (!subkey)
			return 0;
356
		branch = make_branch(name, subkey - name);
357
		if (!strcmp(subkey, ".remote")) {
358 359
			if (!value)
				return config_error_nonbool(key);
360
			branch->remote_name = xstrdup(value);
361
			if (branch == current_branch) {
362
				default_remote_name = branch->remote_name;
363 364
				explicit_default_remote_name = 1;
			}
365 366 367
		} else if (!strcmp(subkey, ".merge")) {
			if (!value)
				return config_error_nonbool(key);
368
			add_merge(branch, xstrdup(value));
369
		}
370
		return 0;
371
	}
372 373
	if (!prefixcmp(key, "url.")) {
		struct rewrite *rewrite;
374
		name = key + 4;
375 376 377 378
		subkey = strrchr(name, '.');
		if (!subkey)
			return 0;
		if (!strcmp(subkey, ".insteadof")) {
379 380 381 382 383 384
			rewrite = make_rewrite(&rewrites, name, subkey - name);
			if (!value)
				return config_error_nonbool(key);
			add_instead_of(rewrite, xstrdup(value));
		} else if (!strcmp(subkey, ".pushinsteadof")) {
			rewrite = make_rewrite(&rewrites_push, name, subkey - name);
385 386 387 388 389
			if (!value)
				return config_error_nonbool(key);
			add_instead_of(rewrite, xstrdup(value));
		}
	}
390 391 392
	if (prefixcmp(key,  "remote."))
		return 0;
	name = key + 7;
393 394 395 396 397
	if (*name == '/') {
		warning("Config remote shorthand cannot begin with '/': %s",
			name);
		return 0;
	}
398 399
	subkey = strrchr(name, '.');
	if (!subkey)
400
		return 0;
401
	remote = make_remote(name, subkey - name);
402
	remote->origin = REMOTE_CONFIG;
403 404 405 406
	if (!strcmp(subkey, ".mirror"))
		remote->mirror = git_config_bool(key, value);
	else if (!strcmp(subkey, ".skipdefaultupdate"))
		remote->skip_default_update = git_config_bool(key, value);
407 408
	else if (!strcmp(subkey, ".skipfetchall"))
		remote->skip_default_update = git_config_bool(key, value);
409 410 411 412 413
	else if (!strcmp(subkey, ".url")) {
		const char *v;
		if (git_config_string(&v, key, value))
			return -1;
		add_url(remote, v);
414 415 416 417 418
	} else if (!strcmp(subkey, ".pushurl")) {
		const char *v;
		if (git_config_string(&v, key, value))
			return -1;
		add_pushurl(remote, v);
419
	} else if (!strcmp(subkey, ".push")) {
420 421 422 423
		const char *v;
		if (git_config_string(&v, key, value))
			return -1;
		add_push_refspec(remote, v);
424
	} else if (!strcmp(subkey, ".fetch")) {
425 426 427 428
		const char *v;
		if (git_config_string(&v, key, value))
			return -1;
		add_fetch_refspec(remote, v);
429
	} else if (!strcmp(subkey, ".receivepack")) {
430 431 432
		const char *v;
		if (git_config_string(&v, key, value))
			return -1;
433
		if (!remote->receivepack)
434
			remote->receivepack = v;
435 436
		else
			error("more than one receivepack given, using the first");
437
	} else if (!strcmp(subkey, ".uploadpack")) {
438 439 440
		const char *v;
		if (git_config_string(&v, key, value))
			return -1;
441
		if (!remote->uploadpack)
442
			remote->uploadpack = v;
443 444
		else
			error("more than one uploadpack given, using the first");
445 446 447
	} else if (!strcmp(subkey, ".tagopt")) {
		if (!strcmp(value, "--no-tags"))
			remote->fetch_tags = -1;
448 449
		else if (!strcmp(value, "--tags"))
			remote->fetch_tags = 2;
S
Sam Vilain 已提交
450
	} else if (!strcmp(subkey, ".proxy")) {
451 452
		return git_config_string((const char **)&remote->http_proxy,
					 key, value);
453 454
	} else if (!strcmp(subkey, ".vcs")) {
		return git_config_string(&remote->foreign_vcs, key, value);
455
	}
456 457 458
	return 0;
}

459 460 461 462
static void alias_all_urls(void)
{
	int i, j;
	for (i = 0; i < remotes_nr; i++) {
463
		int add_pushurl_aliases;
464 465
		if (!remotes[i])
			continue;
466
		for (j = 0; j < remotes[i]->pushurl_nr; j++) {
467
			remotes[i]->pushurl[j] = alias_url(remotes[i]->pushurl[j], &rewrites);
468
		}
469 470 471 472 473 474
		add_pushurl_aliases = remotes[i]->pushurl_nr == 0;
		for (j = 0; j < remotes[i]->url_nr; j++) {
			if (add_pushurl_aliases)
				add_pushurl_alias(remotes[i], remotes[i]->url[j]);
			remotes[i]->url[j] = alias_url(remotes[i]->url[j], &rewrites);
		}
475 476 477
	}
}

478 479 480 481 482
static void read_config(void)
{
	unsigned char sha1[20];
	const char *head_ref;
	int flag;
483
	if (default_remote_name) /* did this already */
484 485 486
		return;
	default_remote_name = xstrdup("origin");
	current_branch = NULL;
487
	head_ref = resolve_ref_unsafe("HEAD", sha1, 0, &flag);
488 489
	if (head_ref && (flag & REF_ISSYMREF) &&
	    !prefixcmp(head_ref, "refs/heads/")) {
490 491
		current_branch =
			make_branch(head_ref + strlen("refs/heads/"), 0);
492
	}
493
	git_config(handle_config, NULL);
494
	alias_all_urls();
495 496
}

497 498 499 500 501 502
/*
 * This function frees a refspec array.
 * Warning: code paths should be checked to ensure that the src
 *          and dst pointers are always freeable pointers as well
 *          as the refspec pointer itself.
 */
503
static void free_refspecs(struct refspec *refspec, int nr_refspec)
504 505 506 507 508 509 510 511 512 513 514 515 516
{
	int i;

	if (!refspec)
		return;

	for (i = 0; i < nr_refspec; i++) {
		free(refspec[i].src);
		free(refspec[i].dst);
	}
	free(refspec);
}

517
static struct refspec *parse_refspec_internal(int nr_refspec, const char **refspec, int fetch, int verify)
518 519 520
{
	int i;
	struct refspec *rs = xcalloc(sizeof(*rs), nr_refspec);
521

522
	for (i = 0; i < nr_refspec; i++) {
523
		size_t llen;
524 525
		int is_glob;
		const char *lhs, *rhs;
526
		int flags;
527

B
Benjamin Kramer 已提交
528
		is_glob = 0;
529 530 531

		lhs = refspec[i];
		if (*lhs == '+') {
532
			rs[i].force = 1;
533
			lhs++;
534
		}
535 536

		rhs = strrchr(lhs, ':');
537 538 539 540 541 542 543 544 545 546

		/*
		 * Before going on, special case ":" (or "+:") as a refspec
		 * for matching refs.
		 */
		if (!fetch && rhs == lhs && rhs[1] == '\0') {
			rs[i].matching = 1;
			continue;
		}

547
		if (rhs) {
548
			size_t rlen = strlen(++rhs);
549
			is_glob = (1 <= rlen && strchr(rhs, '*'));
D
Daniel Barkalow 已提交
550
			rs[i].dst = xstrndup(rhs, rlen);
551
		}
D
Daniel Barkalow 已提交
552

553
		llen = (rhs ? (rhs - lhs - 1) : strlen(lhs));
554
		if (1 <= llen && memchr(lhs, '*', llen)) {
555 556 557 558 559
			if ((rhs && !is_glob) || (!rhs && fetch))
				goto invalid;
			is_glob = 1;
		} else if (rhs && is_glob) {
			goto invalid;
D
Daniel Barkalow 已提交
560
		}
561

562 563
		rs[i].pattern = is_glob;
		rs[i].src = xstrndup(lhs, llen);
564
		flags = REFNAME_ALLOW_ONELEVEL | (is_glob ? REFNAME_REFSPEC_PATTERN : 0);
565 566 567 568 569 570 571 572 573

		if (fetch) {
			/*
			 * LHS
			 * - empty is allowed; it means HEAD.
			 * - otherwise it must be a valid looking ref.
			 */
			if (!*rs[i].src)
				; /* empty is ok */
574 575
			else if (check_refname_format(rs[i].src, flags))
				goto invalid;
576 577
			/*
			 * RHS
578
			 * - missing is ok, and is same as empty.
579 580 581
			 * - empty is ok; it means not to store.
			 * - otherwise it must be a valid looking ref.
			 */
582
			if (!rs[i].dst)
583
				; /* ok */
584
			else if (!*rs[i].dst)
585
				; /* ok */
586 587
			else if (check_refname_format(rs[i].dst, flags))
				goto invalid;
588 589 590 591 592 593 594 595 596 597 598
		} else {
			/*
			 * LHS
			 * - empty is allowed; it means delete.
			 * - when wildcarded, it must be a valid looking ref.
			 * - otherwise, it must be an extended SHA-1, but
			 *   there is no existing way to validate this.
			 */
			if (!*rs[i].src)
				; /* empty is ok */
			else if (is_glob) {
599
				if (check_refname_format(rs[i].src, flags))
600 601 602 603 604 605 606 607 608 609 610 611
					goto invalid;
			}
			else
				; /* anything goes, for now */
			/*
			 * RHS
			 * - missing is allowed, but LHS then must be a
			 *   valid looking ref.
			 * - empty is not allowed.
			 * - otherwise it must be a valid looking ref.
			 */
			if (!rs[i].dst) {
612
				if (check_refname_format(rs[i].src, flags))
613 614 615 616
					goto invalid;
			} else if (!*rs[i].dst) {
				goto invalid;
			} else {
617
				if (check_refname_format(rs[i].dst, flags))
618 619
					goto invalid;
			}
D
Daniel Barkalow 已提交
620
		}
621 622
	}
	return rs;
623 624

 invalid:
625
	if (verify) {
626 627 628 629 630 631
		/*
		 * nr_refspec must be greater than zero and i must be valid
		 * since it is only possible to reach this point from within
		 * the for loop above.
		 */
		free_refspecs(rs, i+1);
632 633
		return NULL;
	}
634 635 636
	die("Invalid refspec '%s'", refspec[i]);
}

637 638 639 640
int valid_fetch_refspec(const char *fetch_refspec_str)
{
	struct refspec *refspec;

641
	refspec = parse_refspec_internal(1, &fetch_refspec_str, 1, 1);
642
	free_refspecs(refspec, 1);
643 644 645
	return !!refspec;
}

646 647
struct refspec *parse_fetch_refspec(int nr_refspec, const char **refspec)
{
648
	return parse_refspec_internal(nr_refspec, refspec, 1, 0);
649 650
}

651
static struct refspec *parse_push_refspec(int nr_refspec, const char **refspec)
652
{
653
	return parse_refspec_internal(nr_refspec, refspec, 0, 0);
654 655
}

656 657 658 659 660 661 662 663 664 665
void free_refspec(int nr_refspec, struct refspec *refspec)
{
	int i;
	for (i = 0; i < nr_refspec; i++) {
		free(refspec[i].src);
		free(refspec[i].dst);
	}
	free(refspec);
}

666 667
static int valid_remote_nick(const char *name)
{
668
	if (!name[0] || is_dot_or_dotdot(name))
669 670 671 672
		return 0;
	return !strchr(name, '/'); /* no slash */
}

673 674 675
struct remote *remote_get(const char *name)
{
	struct remote *ret;
676
	int name_given = 0;
677 678

	read_config();
679 680 681
	if (name)
		name_given = 1;
	else {
682
		name = default_remote_name;
683 684
		name_given = explicit_default_remote_name;
	}
685

686
	ret = make_remote(name, 0);
687
	if (valid_remote_nick(name)) {
688
		if (!valid_remote(ret))
689
			read_remotes_file(ret);
690
		if (!valid_remote(ret))
691 692
			read_branches_file(ret);
	}
693
	if (name_given && !valid_remote(ret))
694
		add_url_alias(ret, name);
695
	if (!valid_remote(ret))
696
		return NULL;
697 698
	ret->fetch = parse_fetch_refspec(ret->fetch_refspec_nr, ret->fetch_refspec);
	ret->push = parse_push_refspec(ret->push_refspec_nr, ret->push_refspec);
699 700
	return ret;
}
701

702 703 704 705 706 707 708 709 710 711 712
int remote_is_configured(const char *name)
{
	int i;
	read_config();

	for (i = 0; i < remotes_nr; i++)
		if (!strcmp(name, remotes[i]->name))
			return 1;
	return 0;
}

713 714 715 716
int for_each_remote(each_remote_fn fn, void *priv)
{
	int i, result = 0;
	read_config();
D
Daniel Barkalow 已提交
717
	for (i = 0; i < remotes_nr && !result; i++) {
718 719 720 721
		struct remote *r = remotes[i];
		if (!r)
			continue;
		if (!r->fetch)
722 723
			r->fetch = parse_fetch_refspec(r->fetch_refspec_nr,
						       r->fetch_refspec);
724
		if (!r->push)
725 726
			r->push = parse_push_refspec(r->push_refspec_nr,
						     r->push_refspec);
727 728 729 730 731
		result = fn(r, priv);
	}
	return result;
}

732 733
void ref_remove_duplicates(struct ref *ref_map)
{
734
	struct string_list refs = STRING_LIST_INIT_NODUP;
735 736 737 738
	struct string_list_item *item = NULL;
	struct ref *prev = NULL, *next = NULL;
	for (; ref_map; prev = ref_map, ref_map = next) {
		next = ref_map->next;
739 740
		if (!ref_map->peer_ref)
			continue;
741

742
		item = string_list_lookup(&refs, ref_map->peer_ref->name);
743 744 745 746 747 748 749 750 751 752
		if (item) {
			if (strcmp(((struct ref *)item->util)->name,
				   ref_map->name))
				die("%s tracks both %s and %s",
				    ref_map->peer_ref->name,
				    ((struct ref *)item->util)->name,
				    ref_map->name);
			prev->next = ref_map->next;
			free(ref_map->peer_ref);
			free(ref_map);
753 754
			ref_map = prev; /* skip this; we freed it */
			continue;
755
		}
756

757
		item = string_list_insert(&refs, ref_map->peer_ref->name);
758
		item->util = ref_map;
759
	}
760
	string_list_clear(&refs, 0);
761 762
}

763
int remote_has_url(struct remote *remote, const char *url)
764 765
{
	int i;
766 767
	for (i = 0; i < remote->url_nr; i++) {
		if (!strcmp(remote->url[i], url))
768 769 770 771 772
			return 1;
	}
	return 0;
}

773 774
static int match_name_with_pattern(const char *key, const char *name,
				   const char *value, char **result)
775
{
D
Daniel Barkalow 已提交
776 777
	const char *kstar = strchr(key, '*');
	size_t klen;
778 779
	size_t ksuffixlen;
	size_t namelen;
D
Daniel Barkalow 已提交
780 781 782 783
	int ret;
	if (!kstar)
		die("Key '%s' of pattern had no '*'", key);
	klen = kstar - key;
784 785 786 787
	ksuffixlen = strlen(kstar + 1);
	namelen = strlen(name);
	ret = !strncmp(name, key, klen) && namelen >= klen + ksuffixlen &&
		!memcmp(name + namelen - ksuffixlen, kstar + 1, ksuffixlen);
788
	if (ret && value) {
D
Daniel Barkalow 已提交
789 790
		const char *vstar = strchr(value, '*');
		size_t vlen;
791
		size_t vsuffixlen;
D
Daniel Barkalow 已提交
792 793 794
		if (!vstar)
			die("Value '%s' of pattern has no '*'", value);
		vlen = vstar - value;
795 796
		vsuffixlen = strlen(vstar + 1);
		*result = xmalloc(vlen + vsuffixlen +
797
				  strlen(name) -
798 799 800 801 802 803
				  klen - ksuffixlen + 1);
		strncpy(*result, value, vlen);
		strncpy(*result + vlen,
			name + klen, namelen - klen - ksuffixlen);
		strcpy(*result + vlen + namelen - klen - ksuffixlen,
		       vstar + 1);
804
	}
805 806 807
	return ret;
}

808
static int query_refspecs(struct refspec *refs, int ref_count, struct refspec *query)
809 810
{
	int i;
811
	int find_src = !query->src;
812

813 814
	if (find_src && !query->dst)
		return error("query_refspecs: need either src or dst");
815

816 817 818 819 820 821
	for (i = 0; i < ref_count; i++) {
		struct refspec *refspec = &refs[i];
		const char *key = find_src ? refspec->dst : refspec->src;
		const char *value = find_src ? refspec->src : refspec->dst;
		const char *needle = find_src ? query->dst : query->src;
		char **result = find_src ? &query->src : &query->dst;
822

823
		if (!refspec->dst)
824
			continue;
825
		if (refspec->pattern) {
826
			if (match_name_with_pattern(key, needle, value, result)) {
827
				query->force = refspec->force;
828 829
				return 0;
			}
830 831
		} else if (!strcmp(needle, key)) {
			*result = xstrdup(value);
832
			query->force = refspec->force;
833
			return 0;
834 835 836 837 838
		}
	}
	return -1;
}

839 840 841 842 843 844 845 846 847 848 849 850 851 852 853 854 855 856 857
char *apply_refspecs(struct refspec *refspecs, int nr_refspec,
		     const char *name)
{
	struct refspec query;

	memset(&query, 0, sizeof(struct refspec));
	query.src = (char *)name;

	if (query_refspecs(refspecs, nr_refspec, &query))
		return NULL;

	return query.dst;
}

int remote_find_tracking(struct remote *remote, struct refspec *refspec)
{
	return query_refspecs(remote->fetch, remote->fetch_refspec_nr, refspec);
}

R
René Scharfe 已提交
858 859 860 861 862 863 864 865 866 867
static struct ref *alloc_ref_with_prefix(const char *prefix, size_t prefixlen,
		const char *name)
{
	size_t len = strlen(name);
	struct ref *ref = xcalloc(1, sizeof(struct ref) + prefixlen + len + 1);
	memcpy(ref->name, prefix, prefixlen);
	memcpy(ref->name + prefixlen, name, len);
	return ref;
}

868
struct ref *alloc_ref(const char *name)
869
{
870
	return alloc_ref_with_prefix("", 0, name);
871 872
}

J
Jeff King 已提交
873
struct ref *copy_ref(const struct ref *ref)
874
{
875 876 877 878 879 880 881 882 883 884 885 886
	struct ref *cpy;
	size_t len;
	if (!ref)
		return NULL;
	len = strlen(ref->name);
	cpy = xmalloc(sizeof(struct ref) + len + 1);
	memcpy(cpy, ref, sizeof(struct ref) + len + 1);
	cpy->next = NULL;
	cpy->symref = ref->symref ? xstrdup(ref->symref) : NULL;
	cpy->remote_status = ref->remote_status ? xstrdup(ref->remote_status) : NULL;
	cpy->peer_ref = copy_ref(ref->peer_ref);
	return cpy;
887 888
}

889 890 891 892 893 894 895 896 897 898 899 900
struct ref *copy_ref_list(const struct ref *ref)
{
	struct ref *ret = NULL;
	struct ref **tail = &ret;
	while (ref) {
		*tail = copy_ref(ref);
		ref = ref->next;
		tail = &((*tail)->next);
	}
	return ret;
}

901
static void free_ref(struct ref *ref)
902 903 904
{
	if (!ref)
		return;
905
	free_ref(ref->peer_ref);
906 907 908 909 910
	free(ref->remote_status);
	free(ref->symref);
	free(ref);
}

911 912 913 914 915
void free_refs(struct ref *ref)
{
	struct ref *next;
	while (ref) {
		next = ref->next;
916
		free_ref(ref);
917 918 919 920
		ref = next;
	}
}

921 922 923 924 925 926 927 928 929 930 931 932 933 934
static int count_refspec_match(const char *pattern,
			       struct ref *refs,
			       struct ref **matched_ref)
{
	int patlen = strlen(pattern);
	struct ref *matched_weak = NULL;
	struct ref *matched = NULL;
	int weak_match = 0;
	int match = 0;

	for (weak_match = match = 0; refs; refs = refs->next) {
		char *name = refs->name;
		int namelen = strlen(name);

935
		if (!refname_match(pattern, name, ref_rev_parse_rules))
936 937 938 939 940 941 942 943 944 945 946 947 948 949 950 951 952 953 954 955 956 957 958 959 960 961 962 963 964 965 966 967 968 969 970 971 972 973 974
			continue;

		/* A match is "weak" if it is with refs outside
		 * heads or tags, and did not specify the pattern
		 * in full (e.g. "refs/remotes/origin/master") or at
		 * least from the toplevel (e.g. "remotes/origin/master");
		 * otherwise "git push $URL master" would result in
		 * ambiguity between remotes/origin/master and heads/master
		 * at the remote site.
		 */
		if (namelen != patlen &&
		    patlen != namelen - 5 &&
		    prefixcmp(name, "refs/heads/") &&
		    prefixcmp(name, "refs/tags/")) {
			/* We want to catch the case where only weak
			 * matches are found and there are multiple
			 * matches, and where more than one strong
			 * matches are found, as ambiguous.  One
			 * strong match with zero or more weak matches
			 * are acceptable as a unique match.
			 */
			matched_weak = refs;
			weak_match++;
		}
		else {
			matched = refs;
			match++;
		}
	}
	if (!matched) {
		*matched_ref = matched_weak;
		return weak_match;
	}
	else {
		*matched_ref = matched;
		return match;
	}
}

975
static void tail_link_ref(struct ref *ref, struct ref ***tail)
976 977
{
	**tail = ref;
978 979
	while (ref->next)
		ref = ref->next;
980 981 982
	*tail = &ref->next;
}

983 984 985 986 987 988 989
static struct ref *alloc_delete_ref(void)
{
	struct ref *ref = alloc_ref("(delete)");
	hashclr(ref->new_sha1);
	return ref;
}

990 991 992 993 994
static struct ref *try_explicit_object_name(const char *name)
{
	unsigned char sha1[20];
	struct ref *ref;

995 996
	if (!*name)
		return alloc_delete_ref();
997 998
	if (get_sha1(name, sha1))
		return NULL;
999
	ref = alloc_ref(name);
1000 1001 1002 1003
	hashcpy(ref->new_sha1, sha1);
	return ref;
}

1004
static struct ref *make_linked_ref(const char *name, struct ref ***tail)
1005
{
1006
	struct ref *ret = alloc_ref(name);
1007 1008
	tail_link_ref(ret, tail);
	return ret;
1009
}
1010

1011 1012 1013 1014 1015
static char *guess_ref(const char *name, struct ref *peer)
{
	struct strbuf buf = STRBUF_INIT;
	unsigned char sha1[20];

1016
	const char *r = resolve_ref_unsafe(peer->name, sha1, 1, NULL);
1017 1018 1019 1020 1021 1022 1023 1024 1025 1026 1027 1028 1029 1030
	if (!r)
		return NULL;

	if (!prefixcmp(r, "refs/heads/"))
		strbuf_addstr(&buf, "refs/heads/");
	else if (!prefixcmp(r, "refs/tags/"))
		strbuf_addstr(&buf, "refs/tags/");
	else
		return NULL;

	strbuf_addstr(&buf, name);
	return strbuf_detach(&buf, NULL);
}

1031 1032
static int match_explicit(struct ref *src, struct ref *dst,
			  struct ref ***dst_tail,
1033
			  struct refspec *rs)
1034
{
1035
	struct ref *matched_src, *matched_dst;
1036
	int copy_src;
1037

1038
	const char *dst_value = rs->dst;
1039
	char *dst_guess;
1040

1041
	if (rs->pattern || rs->matching)
1042
		return 0;
1043

1044 1045 1046
	matched_src = matched_dst = NULL;
	switch (count_refspec_match(rs->src, src, &matched_src)) {
	case 1:
1047
		copy_src = 1;
1048 1049 1050 1051 1052 1053 1054
		break;
	case 0:
		/* The source could be in the get_sha1() format
		 * not a reference name.  :refs/other is a
		 * way to delete 'other' ref at the remote end.
		 */
		matched_src = try_explicit_object_name(rs->src);
1055
		if (!matched_src)
1056
			return error("src refspec %s does not match any.", rs->src);
1057
		copy_src = 0;
1058 1059
		break;
	default:
1060
		return error("src refspec %s matches more than one.", rs->src);
1061
	}
1062

1063
	if (!dst_value) {
1064 1065 1066
		unsigned char sha1[20];
		int flag;

1067
		dst_value = resolve_ref_unsafe(matched_src->name, sha1, 1, &flag);
1068 1069 1070 1071 1072
		if (!dst_value ||
		    ((flag & REF_ISSYMREF) &&
		     prefixcmp(dst_value, "refs/heads/")))
			die("%s cannot be resolved to branch.",
			    matched_src->name);
1073
	}
1074

1075 1076 1077 1078
	switch (count_refspec_match(dst_value, dst, &matched_dst)) {
	case 1:
		break;
	case 0:
1079
		if (!memcmp(dst_value, "refs/", 5))
1080
			matched_dst = make_linked_ref(dst_value, dst_tail);
1081
		else if ((dst_guess = guess_ref(dst_value, matched_src)))
1082
			matched_dst = make_linked_ref(dst_guess, dst_tail);
1083
		else
1084 1085 1086 1087 1088 1089
			error("unable to push to unqualified destination: %s\n"
			      "The destination refspec neither matches an "
			      "existing ref on the remote nor\n"
			      "begins with refs/, and we are unable to "
			      "guess a prefix based on the source ref.",
			      dst_value);
1090 1091
		break;
	default:
1092
		matched_dst = NULL;
1093 1094 1095 1096
		error("dst refspec %s matches more than one.",
		      dst_value);
		break;
	}
1097 1098 1099 1100
	if (!matched_dst)
		return -1;
	if (matched_dst->peer_ref)
		return error("dst ref %s receives from more than one src.",
1101 1102
		      matched_dst->name);
	else {
1103
		matched_dst->peer_ref = copy_src ? copy_ref(matched_src) : matched_src;
1104
		matched_dst->force = rs->force;
1105
	}
1106
	return 0;
1107 1108 1109 1110 1111 1112 1113 1114
}

static int match_explicit_refs(struct ref *src, struct ref *dst,
			       struct ref ***dst_tail, struct refspec *rs,
			       int rs_nr)
{
	int i, errs;
	for (i = errs = 0; i < rs_nr; i++)
1115 1116
		errs += match_explicit(src, dst, dst_tail, &rs[i]);
	return errs;
1117 1118
}

1119
static char *get_ref_match(const struct refspec *rs, int rs_nr, const struct ref *ref,
F
Felipe Contreras 已提交
1120
		int send_mirror, int direction, const struct refspec **ret_pat)
1121
{
1122 1123
	const struct refspec *pat;
	char *name;
1124
	int i;
1125
	int matching_refs = -1;
1126
	for (i = 0; i < rs_nr; i++) {
1127 1128 1129 1130 1131 1132
		if (rs[i].matching &&
		    (matching_refs == -1 || rs[i].force)) {
			matching_refs = i;
			continue;
		}

1133 1134
		if (rs[i].pattern) {
			const char *dst_side = rs[i].dst ? rs[i].dst : rs[i].src;
F
Felipe Contreras 已提交
1135 1136 1137 1138 1139 1140
			int match;
			if (direction == FROM_SRC)
				match = match_name_with_pattern(rs[i].src, ref->name, dst_side, &name);
			else
				match = match_name_with_pattern(dst_side, ref->name, rs[i].src, &name);
			if (match) {
1141 1142 1143 1144
				matching_refs = i;
				break;
			}
		}
1145
	}
1146
	if (matching_refs == -1)
1147
		return NULL;
1148 1149 1150 1151 1152 1153 1154 1155 1156 1157 1158 1159 1160 1161 1162

	pat = rs + matching_refs;
	if (pat->matching) {
		/*
		 * "matching refs"; traditionally we pushed everything
		 * including refs outside refs/heads/ hierarchy, but
		 * that does not make much sense these days.
		 */
		if (!send_mirror && prefixcmp(ref->name, "refs/heads/"))
			return NULL;
		name = xstrdup(ref->name);
	}
	if (ret_pat)
		*ret_pat = pat;
	return name;
1163 1164
}

1165 1166 1167 1168 1169 1170 1171 1172
static struct ref **tail_ref(struct ref **head)
{
	struct ref **tail = head;
	while (*tail)
		tail = &((*tail)->next);
	return tail;
}

1173
/*
1174 1175 1176 1177 1178 1179
 * Given the set of refs the local repository has, the set of refs the
 * remote repository has, and the refspec used for push, determine
 * what remote refs we will update and with what value by setting
 * peer_ref (which object is being pushed) and force (if the push is
 * forced) in elements of "dst". The function may add new elements to
 * dst (e.g. pushing to a new branch, done in match_explicit_refs).
1180
 */
1181 1182
int match_push_refs(struct ref *src, struct ref **dst,
		    int nr_refspec, const char **refspec, int flags)
1183
{
1184
	struct refspec *rs;
A
Andy Whitcroft 已提交
1185 1186
	int send_all = flags & MATCH_REFS_ALL;
	int send_mirror = flags & MATCH_REFS_MIRROR;
F
Felipe Contreras 已提交
1187
	int send_prune = flags & MATCH_REFS_PRUNE;
1188
	int errs;
1189
	static const char *default_refspec[] = { ":", NULL };
1190
	struct ref *ref, **dst_tail = tail_ref(dst);
1191

1192 1193 1194 1195 1196
	if (!nr_refspec) {
		nr_refspec = 1;
		refspec = default_refspec;
	}
	rs = parse_push_refspec(nr_refspec, (const char **) refspec);
1197
	errs = match_explicit_refs(src, *dst, &dst_tail, rs, nr_refspec);
1198 1199

	/* pick the remainder */
1200
	for (ref = src; ref; ref = ref->next) {
1201
		struct ref *dst_peer;
1202 1203
		const struct refspec *pat = NULL;
		char *dst_name;
1204

1205
		if (ref->peer_ref)
1206
			continue;
1207

F
Felipe Contreras 已提交
1208
		dst_name = get_ref_match(rs, nr_refspec, ref, send_mirror, FROM_SRC, &pat);
1209
		if (!dst_name)
1210 1211
			continue;

1212
		dst_peer = find_ref_by_name(*dst, dst_name);
1213 1214 1215 1216 1217 1218 1219 1220 1221 1222 1223 1224
		if (dst_peer) {
			if (dst_peer->peer_ref)
				/* We're already sending something to this ref. */
				goto free_name;
		} else {
			if (pat->matching && !(send_all || send_mirror))
				/*
				 * Remote doesn't have it, and we have no
				 * explicit pattern, and we don't have
				 * --all nor --mirror.
				 */
				goto free_name;
A
Andy Whitcroft 已提交
1225

1226
			/* Create a new one and link it */
1227
			dst_peer = make_linked_ref(dst_name, &dst_tail);
1228
			hashcpy(dst_peer->new_sha1, ref->new_sha1);
1229
		}
1230
		dst_peer->peer_ref = copy_ref(ref);
1231
		dst_peer->force = pat->force;
1232 1233
	free_name:
		free(dst_name);
1234
	}
F
Felipe Contreras 已提交
1235 1236 1237 1238 1239 1240 1241 1242 1243 1244 1245 1246 1247 1248 1249 1250 1251
	if (send_prune) {
		/* check for missing refs on the remote */
		for (ref = *dst; ref; ref = ref->next) {
			char *src_name;

			if (ref->peer_ref)
				/* We're already sending something to this ref. */
				continue;

			src_name = get_ref_match(rs, nr_refspec, ref, send_mirror, FROM_DST, NULL);
			if (src_name) {
				if (!find_ref_by_name(src, src_name))
					ref->peer_ref = alloc_delete_ref();
				free(src_name);
			}
		}
	}
1252 1253
	if (errs)
		return -1;
1254 1255
	return 0;
}
1256

1257 1258 1259 1260 1261 1262 1263 1264 1265 1266 1267 1268 1269 1270 1271 1272 1273 1274 1275 1276 1277 1278 1279 1280 1281 1282 1283 1284 1285 1286 1287 1288 1289 1290 1291 1292 1293 1294 1295 1296 1297 1298 1299 1300 1301 1302 1303 1304 1305 1306
void set_ref_status_for_push(struct ref *remote_refs, int send_mirror,
	int force_update)
{
	struct ref *ref;

	for (ref = remote_refs; ref; ref = ref->next) {
		if (ref->peer_ref)
			hashcpy(ref->new_sha1, ref->peer_ref->new_sha1);
		else if (!send_mirror)
			continue;

		ref->deletion = is_null_sha1(ref->new_sha1);
		if (!ref->deletion &&
			!hashcmp(ref->old_sha1, ref->new_sha1)) {
			ref->status = REF_STATUS_UPTODATE;
			continue;
		}

		/* This part determines what can overwrite what.
		 * The rules are:
		 *
		 * (0) you can always use --force or +A:B notation to
		 *     selectively force individual ref pairs.
		 *
		 * (1) if the old thing does not exist, it is OK.
		 *
		 * (2) if you do not have the old thing, you are not allowed
		 *     to overwrite it; you would not know what you are losing
		 *     otherwise.
		 *
		 * (3) if both new and old are commit-ish, and new is a
		 *     descendant of old, it is OK.
		 *
		 * (4) regardless of all of the above, removing :B is
		 *     always allowed.
		 */

		ref->nonfastforward =
			!ref->deletion &&
			!is_null_sha1(ref->old_sha1) &&
			(!has_sha1_file(ref->old_sha1)
			  || !ref_newer(ref->new_sha1, ref->old_sha1));

		if (ref->nonfastforward && !ref->force && !force_update) {
			ref->status = REF_STATUS_REJECT_NONFASTFORWARD;
			continue;
		}
	}
}

1307 1308 1309 1310 1311 1312 1313 1314 1315 1316 1317 1318 1319 1320 1321 1322 1323 1324
struct branch *branch_get(const char *name)
{
	struct branch *ret;

	read_config();
	if (!name || !*name || !strcmp(name, "HEAD"))
		ret = current_branch;
	else
		ret = make_branch(name, 0);
	if (ret && ret->remote_name) {
		ret->remote = remote_get(ret->remote_name);
		if (ret->merge_nr) {
			int i;
			ret->merge = xcalloc(sizeof(*ret->merge),
					     ret->merge_nr);
			for (i = 0; i < ret->merge_nr; i++) {
				ret->merge[i] = xcalloc(1, sizeof(**ret->merge));
				ret->merge[i]->src = xstrdup(ret->merge_name[i]);
1325 1326 1327
				if (remote_find_tracking(ret->remote, ret->merge[i])
				    && !strcmp(ret->remote_name, "."))
					ret->merge[i]->dst = xstrdup(ret->merge_name[i]);
1328 1329 1330 1331 1332 1333 1334 1335 1336 1337 1338
			}
		}
	}
	return ret;
}

int branch_has_merge_config(struct branch *branch)
{
	return branch && !!branch->merge;
}

1339 1340 1341
int branch_merge_matches(struct branch *branch,
		                 int i,
		                 const char *refname)
1342
{
1343
	if (!branch || i < 0 || i >= branch->merge_nr)
1344
		return 0;
1345
	return refname_match(branch->merge[i]->src, refname, ref_fetch_rules);
1346
}
1347

1348
static struct ref *get_expanded_map(const struct ref *remote_refs,
1349 1350
				    const struct refspec *refspec)
{
1351
	const struct ref *ref;
1352 1353 1354
	struct ref *ret = NULL;
	struct ref **tail = &ret;

1355
	char *expn_name;
1356 1357 1358 1359

	for (ref = remote_refs; ref; ref = ref->next) {
		if (strchr(ref->name, '^'))
			continue; /* a dereference item */
1360 1361
		if (match_name_with_pattern(refspec->src, ref->name,
					    refspec->dst, &expn_name)) {
1362 1363
			struct ref *cpy = copy_ref(ref);

1364 1365
			cpy->peer_ref = alloc_ref(expn_name);
			free(expn_name);
1366 1367 1368 1369 1370 1371 1372 1373 1374 1375
			if (refspec->force)
				cpy->peer_ref->force = 1;
			*tail = cpy;
			tail = &cpy->next;
		}
	}

	return ret;
}

1376
static const struct ref *find_ref_by_name_abbrev(const struct ref *refs, const char *name)
1377
{
1378
	const struct ref *ref;
1379
	for (ref = refs; ref; ref = ref->next) {
1380
		if (refname_match(name, ref->name, ref_fetch_rules))
1381 1382 1383 1384 1385
			return ref;
	}
	return NULL;
}

1386
struct ref *get_remote_ref(const struct ref *remote_refs, const char *name)
1387
{
1388
	const struct ref *ref = find_ref_by_name_abbrev(remote_refs, name);
1389 1390

	if (!ref)
1391
		return NULL;
1392 1393 1394 1395 1396 1397

	return copy_ref(ref);
}

static struct ref *get_local_ref(const char *name)
{
1398
	if (!name || name[0] == '\0')
1399 1400
		return NULL;

1401 1402
	if (!prefixcmp(name, "refs/"))
		return alloc_ref(name);
1403 1404 1405

	if (!prefixcmp(name, "heads/") ||
	    !prefixcmp(name, "tags/") ||
R
René Scharfe 已提交
1406 1407
	    !prefixcmp(name, "remotes/"))
		return alloc_ref_with_prefix("refs/", 5, name);
1408

R
René Scharfe 已提交
1409
	return alloc_ref_with_prefix("refs/heads/", 11, name);
1410 1411
}

1412
int get_fetch_map(const struct ref *remote_refs,
1413
		  const struct refspec *refspec,
1414 1415
		  struct ref ***tail,
		  int missing_ok)
1416
{
D
Daniel Barkalow 已提交
1417
	struct ref *ref_map, **rmp;
1418 1419 1420 1421

	if (refspec->pattern) {
		ref_map = get_expanded_map(remote_refs, refspec);
	} else {
1422 1423 1424 1425 1426 1427 1428 1429 1430 1431
		const char *name = refspec->src[0] ? refspec->src : "HEAD";

		ref_map = get_remote_ref(remote_refs, name);
		if (!missing_ok && !ref_map)
			die("Couldn't find remote ref %s", name);
		if (ref_map) {
			ref_map->peer_ref = get_local_ref(refspec->dst);
			if (ref_map->peer_ref && refspec->force)
				ref_map->peer_ref->force = 1;
		}
1432 1433
	}

D
Daniel Barkalow 已提交
1434 1435
	for (rmp = &ref_map; *rmp; ) {
		if ((*rmp)->peer_ref) {
1436 1437
			if (check_refname_format((*rmp)->peer_ref->name + 5,
				REFNAME_ALLOW_ONELEVEL)) {
D
Daniel Barkalow 已提交
1438 1439 1440 1441 1442 1443 1444 1445 1446 1447
				struct ref *ignore = *rmp;
				error("* Ignoring funny ref '%s' locally",
				      (*rmp)->peer_ref->name);
				*rmp = (*rmp)->next;
				free(ignore->peer_ref);
				free(ignore);
				continue;
			}
		}
		rmp = &((*rmp)->next);
1448 1449
	}

1450 1451
	if (ref_map)
		tail_link_ref(ref_map, tail);
1452 1453 1454

	return 0;
}
1455 1456 1457 1458 1459 1460 1461 1462 1463 1464 1465 1466

int resolve_remote_symref(struct ref *ref, struct ref *list)
{
	if (!ref->symref)
		return 0;
	for (; list; list = list->next)
		if (!strcmp(ref->symref, list->name)) {
			hashcpy(ref->old_sha1, list->old_sha1);
			return 0;
		}
	return 1;
}
1467

1468 1469 1470 1471 1472 1473 1474 1475 1476 1477 1478 1479 1480 1481 1482 1483 1484 1485 1486 1487 1488 1489 1490 1491 1492 1493 1494 1495 1496 1497 1498 1499 1500 1501 1502 1503 1504 1505 1506 1507 1508 1509 1510 1511 1512 1513 1514 1515
static void unmark_and_free(struct commit_list *list, unsigned int mark)
{
	while (list) {
		struct commit_list *temp = list;
		temp->item->object.flags &= ~mark;
		list = temp->next;
		free(temp);
	}
}

int ref_newer(const unsigned char *new_sha1, const unsigned char *old_sha1)
{
	struct object *o;
	struct commit *old, *new;
	struct commit_list *list, *used;
	int found = 0;

	/* Both new and old must be commit-ish and new is descendant of
	 * old.  Otherwise we require --force.
	 */
	o = deref_tag(parse_object(old_sha1), NULL, 0);
	if (!o || o->type != OBJ_COMMIT)
		return 0;
	old = (struct commit *) o;

	o = deref_tag(parse_object(new_sha1), NULL, 0);
	if (!o || o->type != OBJ_COMMIT)
		return 0;
	new = (struct commit *) o;

	if (parse_commit(new) < 0)
		return 0;

	used = list = NULL;
	commit_list_insert(new, &list);
	while (list) {
		new = pop_most_recent_commit(&list, TMP_MARK);
		commit_list_insert(new, &used);
		if (new == old) {
			found = 1;
			break;
		}
	}
	unmark_and_free(list, TMP_MARK);
	unmark_and_free(used, TMP_MARK);
	return found;
}

1516 1517 1518 1519 1520 1521 1522 1523 1524 1525 1526 1527 1528 1529 1530 1531 1532 1533 1534 1535 1536 1537 1538 1539 1540
/*
 * Return true if there is anything to report, otherwise false.
 */
int stat_tracking_info(struct branch *branch, int *num_ours, int *num_theirs)
{
	unsigned char sha1[20];
	struct commit *ours, *theirs;
	char symmetric[84];
	struct rev_info revs;
	const char *rev_argv[10], *base;
	int rev_argc;

	/*
	 * Nothing to report unless we are marked to build on top of
	 * somebody else.
	 */
	if (!branch ||
	    !branch->merge || !branch->merge[0] || !branch->merge[0]->dst)
		return 0;

	/*
	 * If what we used to build on no longer exists, there is
	 * nothing to report.
	 */
	base = branch->merge[0]->dst;
1541
	if (read_ref(base, sha1))
1542
		return 0;
1543
	theirs = lookup_commit_reference(sha1);
1544 1545 1546
	if (!theirs)
		return 0;

1547
	if (read_ref(branch->refname, sha1))
1548
		return 0;
1549
	ours = lookup_commit_reference(sha1);
1550 1551 1552 1553 1554 1555 1556
	if (!ours)
		return 0;

	/* are we the same? */
	if (theirs == ours)
		return 0;

1557
	/* Run "rev-list --left-right ours...theirs" internally... */
1558 1559 1560 1561 1562 1563 1564 1565 1566 1567 1568 1569 1570 1571 1572 1573 1574 1575 1576 1577 1578 1579 1580 1581 1582 1583 1584
	rev_argc = 0;
	rev_argv[rev_argc++] = NULL;
	rev_argv[rev_argc++] = "--left-right";
	rev_argv[rev_argc++] = symmetric;
	rev_argv[rev_argc++] = "--";
	rev_argv[rev_argc] = NULL;

	strcpy(symmetric, sha1_to_hex(ours->object.sha1));
	strcpy(symmetric + 40, "...");
	strcpy(symmetric + 43, sha1_to_hex(theirs->object.sha1));

	init_revisions(&revs, NULL);
	setup_revisions(rev_argc, rev_argv, &revs, NULL);
	prepare_revision_walk(&revs);

	/* ... and count the commits on each side. */
	*num_ours = 0;
	*num_theirs = 0;
	while (1) {
		struct commit *c = get_revision(&revs);
		if (!c)
			break;
		if (c->object.flags & SYMMETRIC_LEFT)
			(*num_ours)++;
		else
			(*num_theirs)++;
	}
1585 1586 1587 1588

	/* clear object flags smudged by the above traversal */
	clear_commit_marks(ours, ALL_REV_FLAGS);
	clear_commit_marks(theirs, ALL_REV_FLAGS);
1589 1590 1591 1592 1593 1594 1595 1596 1597
	return 1;
}

/*
 * Return true when there is anything to report, otherwise false.
 */
int format_tracking_info(struct branch *branch, struct strbuf *sb)
{
	int num_ours, num_theirs;
1598
	const char *base;
1599 1600 1601 1602 1603

	if (!stat_tracking_info(branch, &num_ours, &num_theirs))
		return 0;

	base = branch->merge[0]->dst;
1604
	base = shorten_unambiguous_ref(base, 0);
1605
	if (!num_theirs)
1606 1607 1608 1609 1610
		strbuf_addf(sb,
			Q_("Your branch is ahead of '%s' by %d commit.\n",
			   "Your branch is ahead of '%s' by %d commits.\n",
			   num_ours),
			base, num_ours);
1611
	else if (!num_ours)
1612 1613 1614 1615 1616 1617 1618
		strbuf_addf(sb,
			Q_("Your branch is behind '%s' by %d commit, "
			       "and can be fast-forwarded.\n",
			   "Your branch is behind '%s' by %d commits, "
			       "and can be fast-forwarded.\n",
			   num_theirs),
			base, num_theirs);
1619
	else
1620 1621 1622 1623 1624 1625 1626 1627 1628
		strbuf_addf(sb,
			Q_("Your branch and '%s' have diverged,\n"
			       "and have %d and %d different commit each, "
			       "respectively.\n",
			   "Your branch and '%s' have diverged,\n"
			       "and have %d and %d different commits each, "
			       "respectively.\n",
			   num_theirs),
			base, num_ours, num_theirs);
1629 1630
	return 1;
}
1631 1632 1633 1634 1635 1636 1637 1638

static int one_local_ref(const char *refname, const unsigned char *sha1, int flag, void *cb_data)
{
	struct ref ***local_tail = cb_data;
	struct ref *ref;
	int len;

	/* we already know it starts with refs/ to get here */
1639
	if (check_refname_format(refname + 5, 0))
1640 1641 1642 1643 1644 1645 1646 1647 1648 1649 1650 1651 1652
		return 0;

	len = strlen(refname) + 1;
	ref = xcalloc(1, sizeof(*ref) + len);
	hashcpy(ref->new_sha1, sha1);
	memcpy(ref->name, refname, len);
	**local_tail = ref;
	*local_tail = &ref->next;
	return 0;
}

struct ref *get_local_heads(void)
{
1653
	struct ref *local_refs = NULL, **local_tail = &local_refs;
1654 1655 1656
	for_each_ref(one_local_ref, &local_tail);
	return local_refs;
}
J
Jay Soffian 已提交
1657

1658 1659 1660
struct ref *guess_remote_head(const struct ref *head,
			      const struct ref *refs,
			      int all)
J
Jay Soffian 已提交
1661 1662
{
	const struct ref *r;
1663 1664
	struct ref *list = NULL;
	struct ref **tail = &list;
J
Jay Soffian 已提交
1665

1666
	if (!head)
J
Jay Soffian 已提交
1667 1668
		return NULL;

1669 1670 1671 1672 1673 1674 1675 1676
	/*
	 * Some transports support directly peeking at
	 * where HEAD points; if that is the case, then
	 * we don't have to guess.
	 */
	if (head->symref)
		return copy_ref(find_ref_by_name(refs, head->symref));

J
Jay Soffian 已提交
1677
	/* If refs/heads/master could be right, it is. */
1678 1679 1680 1681 1682
	if (!all) {
		r = find_ref_by_name(refs, "refs/heads/master");
		if (r && !hashcmp(r->old_sha1, head->old_sha1))
			return copy_ref(r);
	}
J
Jay Soffian 已提交
1683 1684

	/* Look for another ref that points there */
1685
	for (r = refs; r; r = r->next) {
1686 1687 1688
		if (r != head &&
		    !prefixcmp(r->name, "refs/heads/") &&
		    !hashcmp(r->old_sha1, head->old_sha1)) {
1689 1690 1691 1692 1693 1694
			*tail = copy_ref(r);
			tail = &((*tail)->next);
			if (!all)
				break;
		}
	}
J
Jay Soffian 已提交
1695

1696
	return list;
J
Jay Soffian 已提交
1697
}
1698 1699 1700 1701

struct stale_heads_info {
	struct string_list *ref_names;
	struct ref **stale_refs_tail;
1702 1703
	struct refspec *refs;
	int ref_count;
1704 1705 1706 1707 1708 1709
};

static int get_stale_heads_cb(const char *refname,
	const unsigned char *sha1, int flags, void *cb_data)
{
	struct stale_heads_info *info = cb_data;
1710 1711 1712 1713 1714 1715 1716 1717 1718 1719 1720 1721 1722 1723 1724 1725
	struct refspec query;
	memset(&query, 0, sizeof(struct refspec));
	query.dst = (char *)refname;

	if (query_refspecs(info->refs, info->ref_count, &query))
		return 0; /* No matches */

	/*
	 * If we did find a suitable refspec and it's not a symref and
	 * it's not in the list of refs that currently exist in that
	 * remote we consider it to be stale.
	 */
	if (!((flags & REF_ISSYMREF) ||
	      string_list_has_string(info->ref_names, query.src))) {
		struct ref *ref = make_linked_ref(refname, &info->stale_refs_tail);
		hashcpy(ref->new_sha1, sha1);
1726
	}
1727 1728

	free(query.src);
1729 1730 1731
	return 0;
}

1732
struct ref *get_stale_heads(struct refspec *refs, int ref_count, struct ref *fetch_map)
1733 1734
{
	struct ref *ref, *stale_refs = NULL;
1735
	struct string_list ref_names = STRING_LIST_INIT_NODUP;
1736 1737 1738
	struct stale_heads_info info;
	info.ref_names = &ref_names;
	info.stale_refs_tail = &stale_refs;
1739 1740
	info.refs = refs;
	info.ref_count = ref_count;
1741
	for (ref = fetch_map; ref; ref = ref->next)
1742
		string_list_append(&ref_names, ref->name);
1743 1744 1745 1746 1747
	sort_string_list(&ref_names);
	for_each_ref(get_stale_heads_cb, &info);
	string_list_clear(&ref_names, 0);
	return stale_refs;
}