submodule.c 29.2 KB
Newer Older
1
#include "cache.h"
2
#include "submodule-config.h"
3 4 5 6 7
#include "submodule.h"
#include "dir.h"
#include "diff.h"
#include "commit.h"
#include "revision.h"
8
#include "run-command.h"
9
#include "diffcore.h"
10
#include "refs.h"
11
#include "string-list.h"
12
#include "sha1-array.h"
13
#include "argv-array.h"
14
#include "blob.h"
15

16
static int config_fetch_recurse_submodules = RECURSE_SUBMODULES_ON_DEMAND;
17
static struct string_list changed_submodule_paths;
18 19 20 21
static int initialized_fetch_ref_tips;
static struct sha1_array ref_tips_before_fetch;
static struct sha1_array ref_tips_after_fetch;

22 23 24 25 26 27 28 29 30
/*
 * The following flag is set if the .gitmodules file is unmerged. We then
 * disable recursion for all submodules where .git/config doesn't have a
 * matching config entry because we can't guess what might be configured in
 * .gitmodules unless the user resolves the conflict. When a command line
 * option is given (which always overrides configuration) this flag will be
 * ignored.
 */
static int gitmodules_is_unmerged;
31

32 33 34 35 36 37 38 39 40 41 42 43 44 45 46
/*
 * This flag is set if the .gitmodules file had unstaged modifications on
 * startup. This must be checked before allowing modifications to the
 * .gitmodules file with the intention to stage them later, because when
 * continuing we would stage the modifications the user didn't stage herself
 * too. That might change in a future version when we learn to stage the
 * changes we do ourselves without staging any previous modifications.
 */
static int gitmodules_is_modified;

int is_staging_gitmodules_ok(void)
{
	return !gitmodules_is_modified;
}

47 48 49 50 51 52 53 54
/*
 * Try to update the "path" entry in the "submodule.<name>" section of the
 * .gitmodules file. Return 0 only if a .gitmodules file was found, a section
 * with the correct path=<oldpath> setting was found and we could update it.
 */
int update_path_in_gitmodules(const char *oldpath, const char *newpath)
{
	struct strbuf entry = STRBUF_INIT;
55
	const struct submodule *submodule;
56 57 58 59 60 61 62

	if (!file_exists(".gitmodules")) /* Do nothing without .gitmodules */
		return -1;

	if (gitmodules_is_unmerged)
		die(_("Cannot change unmerged .gitmodules, resolve merge conflicts first"));

63 64
	submodule = submodule_from_path(null_sha1, oldpath);
	if (!submodule || !submodule->name) {
65 66 67 68
		warning(_("Could not find section in .gitmodules where path=%s"), oldpath);
		return -1;
	}
	strbuf_addstr(&entry, "submodule.");
69
	strbuf_addstr(&entry, submodule->name);
70 71 72 73 74 75 76 77 78 79 80
	strbuf_addstr(&entry, ".path");
	if (git_config_set_in_file(".gitmodules", entry.buf, newpath) < 0) {
		/* Maybe the user already did that, don't error out here */
		warning(_("Could not update .gitmodules entry %s"), entry.buf);
		strbuf_release(&entry);
		return -1;
	}
	strbuf_release(&entry);
	return 0;
}

81 82 83 84 85 86 87 88
/*
 * Try to remove the "submodule.<name>" section from .gitmodules where the given
 * path is configured. Return 0 only if a .gitmodules file was found, a section
 * with the correct path=<path> setting was found and we could remove it.
 */
int remove_path_from_gitmodules(const char *path)
{
	struct strbuf sect = STRBUF_INIT;
89
	const struct submodule *submodule;
90 91 92 93 94 95 96

	if (!file_exists(".gitmodules")) /* Do nothing without .gitmodules */
		return -1;

	if (gitmodules_is_unmerged)
		die(_("Cannot change unmerged .gitmodules, resolve merge conflicts first"));

97 98
	submodule = submodule_from_path(null_sha1, path);
	if (!submodule || !submodule->name) {
99 100 101 102
		warning(_("Could not find section in .gitmodules where path=%s"), path);
		return -1;
	}
	strbuf_addstr(&sect, "submodule.");
103
	strbuf_addstr(&sect, submodule->name);
104 105 106 107 108 109 110 111 112 113
	if (git_config_rename_section_in_file(".gitmodules", sect.buf, NULL) < 0) {
		/* Maybe the user already did that, don't error out here */
		warning(_("Could not remove .gitmodules entry for %s"), path);
		strbuf_release(&sect);
		return -1;
	}
	strbuf_release(&sect);
	return 0;
}

114 115
void stage_updated_gitmodules(void)
{
116
	if (add_file_to_cache(".gitmodules", 0))
117 118 119
		die(_("staging updated .gitmodules failed"));
}

120
static int add_submodule_odb(const char *path)
121 122 123
{
	struct strbuf objects_directory = STRBUF_INIT;
	struct alternate_object_database *alt_odb;
J
Jens Lehmann 已提交
124
	int ret = 0;
125
	int alloc;
126

127
	strbuf_git_path_submodule(&objects_directory, path, "objects/");
J
Jens Lehmann 已提交
128 129 130 131
	if (!is_directory(objects_directory.buf)) {
		ret = -1;
		goto done;
	}
132
	/* avoid adding it twice */
133
	prepare_alt_odb();
134 135 136 137
	for (alt_odb = alt_odb_list; alt_odb; alt_odb = alt_odb->next)
		if (alt_odb->name - alt_odb->base == objects_directory.len &&
				!strncmp(alt_odb->base, objects_directory.buf,
					objects_directory.len))
J
Jens Lehmann 已提交
138
			goto done;
139

140 141
	alloc = objects_directory.len + 42; /* for "12/345..." sha1 */
	alt_odb = xmalloc(sizeof(*alt_odb) + alloc);
142
	alt_odb->next = alt_odb_list;
143
	xsnprintf(alt_odb->base, alloc, "%s", objects_directory.buf);
144 145 146 147 148
	alt_odb->name = alt_odb->base + objects_directory.len;
	alt_odb->name[2] = '/';
	alt_odb->name[40] = '\0';
	alt_odb->name[41] = '\0';
	alt_odb_list = alt_odb;
149 150 151

	/* add possible alternates from the submodule */
	read_info_alternates(objects_directory.buf, 0);
J
Jens Lehmann 已提交
152 153 154
done:
	strbuf_release(&objects_directory);
	return ret;
155 156
}

157 158 159
void set_diffopt_flags_from_submodule_config(struct diff_options *diffopt,
					     const char *path)
{
160 161 162 163
	const struct submodule *submodule = submodule_from_path(null_sha1, path);
	if (submodule) {
		if (submodule->ignore)
			handle_ignore_submodules_arg(diffopt, submodule->ignore);
164 165
		else if (gitmodules_is_unmerged)
			DIFF_OPT_SET(diffopt, IGNORE_SUBMODULES);
166 167 168
	}
}

169
int submodule_config(const char *var, const char *value, void *cb)
170
{
171
	if (starts_with(var, "submodule."))
172
		return parse_submodule_config_option(var, value);
173
	else if (!strcmp(var, "fetch.recursesubmodules")) {
174
		config_fetch_recurse_submodules = parse_fetch_recurse_submodules_arg(var, value);
175 176
		return 0;
	}
177 178 179 180 181 182 183 184
	return 0;
}

void gitmodules_config(void)
{
	const char *work_tree = get_git_work_tree();
	if (work_tree) {
		struct strbuf gitmodules_path = STRBUF_INIT;
185
		int pos;
186 187
		strbuf_addstr(&gitmodules_path, work_tree);
		strbuf_addstr(&gitmodules_path, "/.gitmodules");
188 189 190 191 192 193 194 195 196 197 198
		if (read_cache() < 0)
			die("index file corrupt");
		pos = cache_name_pos(".gitmodules", 11);
		if (pos < 0) { /* .gitmodules not found or isn't merged */
			pos = -1 - pos;
			if (active_nr > pos) {  /* there is a .gitmodules */
				const struct cache_entry *ce = active_cache[pos];
				if (ce_namelen(ce) == 11 &&
				    !memcmp(ce->name, ".gitmodules", 11))
					gitmodules_is_unmerged = 1;
			}
199 200 201 202 203
		} else if (pos < active_nr) {
			struct stat st;
			if (lstat(".gitmodules", &st) == 0 &&
			    ce_match_stat(active_cache[pos], &st, 0) & DATA_CHANGED)
				gitmodules_is_modified = 1;
204 205 206 207
		}

		if (!gitmodules_is_unmerged)
			git_config_from_file(submodule_config, gitmodules_path.buf, NULL);
208 209 210 211
		strbuf_release(&gitmodules_path);
	}
}

212 213 214
void handle_ignore_submodules_arg(struct diff_options *diffopt,
				  const char *arg)
{
215 216 217 218
	DIFF_OPT_CLR(diffopt, IGNORE_SUBMODULES);
	DIFF_OPT_CLR(diffopt, IGNORE_UNTRACKED_IN_SUBMODULES);
	DIFF_OPT_CLR(diffopt, IGNORE_DIRTY_SUBMODULES);

219 220 221 222 223 224
	if (!strcmp(arg, "all"))
		DIFF_OPT_SET(diffopt, IGNORE_SUBMODULES);
	else if (!strcmp(arg, "untracked"))
		DIFF_OPT_SET(diffopt, IGNORE_UNTRACKED_IN_SUBMODULES);
	else if (!strcmp(arg, "dirty"))
		DIFF_OPT_SET(diffopt, IGNORE_DIRTY_SUBMODULES);
225
	else if (strcmp(arg, "none"))
226 227 228
		die("bad --ignore-submodules argument: %s", arg);
}

229 230 231 232 233 234 235 236 237 238 239 240 241
static int prepare_submodule_summary(struct rev_info *rev, const char *path,
		struct commit *left, struct commit *right,
		int *fast_forward, int *fast_backward)
{
	struct commit_list *merge_bases, *list;

	init_revisions(rev, NULL);
	setup_revisions(0, NULL, rev, NULL);
	rev->left_right = 1;
	rev->first_parent_only = 1;
	left->object.flags |= SYMMETRIC_LEFT;
	add_pending_object(rev, &left->object, path);
	add_pending_object(rev, &right->object, path);
242
	merge_bases = get_merge_bases(left, right);
243 244 245 246 247 248 249 250 251
	if (merge_bases) {
		if (merge_bases->item == left)
			*fast_forward = 1;
		else if (merge_bases->item == right)
			*fast_backward = 1;
	}
	for (list = merge_bases; list; list = list->next) {
		list->item->object.flags |= UNINTERESTING;
		add_pending_object(rev, &list->item->object,
252
			oid_to_hex(&list->item->object.oid));
253 254 255 256 257
	}
	return prepare_revision_walk(rev);
}

static void print_submodule_summary(struct rev_info *rev, FILE *f,
258
		const char *line_prefix,
259 260 261 262 263 264 265 266 267
		const char *del, const char *add, const char *reset)
{
	static const char format[] = "  %m %s";
	struct strbuf sb = STRBUF_INIT;
	struct commit *commit;

	while ((commit = get_revision(rev))) {
		struct pretty_print_context ctx = {0};
		ctx.date_mode = rev->date_mode;
268
		ctx.output_encoding = get_log_output_encoding();
269
		strbuf_setlen(&sb, 0);
270
		strbuf_addstr(&sb, line_prefix);
271 272 273 274 275 276 277 278 279 280 281 282 283 284 285
		if (commit->object.flags & SYMMETRIC_LEFT) {
			if (del)
				strbuf_addstr(&sb, del);
		}
		else if (add)
			strbuf_addstr(&sb, add);
		format_commit_message(commit, format, &sb, &ctx);
		if (reset)
			strbuf_addstr(&sb, reset);
		strbuf_addch(&sb, '\n');
		fprintf(f, "%s", sb.buf);
	}
	strbuf_release(&sb);
}

286
void show_submodule_summary(FILE *f, const char *path,
287
		const char *line_prefix,
288
		unsigned char one[20], unsigned char two[20],
289
		unsigned dirty_submodule, const char *meta,
290 291 292
		const char *del, const char *add, const char *reset)
{
	struct rev_info rev;
293
	struct commit *left = NULL, *right = NULL;
294 295 296 297 298 299 300 301 302 303 304 305 306
	const char *message = NULL;
	struct strbuf sb = STRBUF_INIT;
	int fast_forward = 0, fast_backward = 0;

	if (is_null_sha1(two))
		message = "(submodule deleted)";
	else if (add_submodule_odb(path))
		message = "(not checked out)";
	else if (is_null_sha1(one))
		message = "(new submodule)";
	else if (!(left = lookup_commit_reference(one)) ||
		 !(right = lookup_commit_reference(two)))
		message = "(commits not present)";
307 308
	else if (prepare_submodule_summary(&rev, path, left, right,
					   &fast_forward, &fast_backward))
309
		message = "(revision walker failed)";
310

311
	if (dirty_submodule & DIRTY_SUBMODULE_UNTRACKED)
312 313
		fprintf(f, "%sSubmodule %s contains untracked content\n",
			line_prefix, path);
314
	if (dirty_submodule & DIRTY_SUBMODULE_MODIFIED)
315 316
		fprintf(f, "%sSubmodule %s contains modified content\n",
			line_prefix, path);
317 318 319 320 321 322

	if (!hashcmp(one, two)) {
		strbuf_release(&sb);
		return;
	}

323
	strbuf_addf(&sb, "%s%sSubmodule %s %s..", line_prefix, meta, path,
324 325 326 327 328
			find_unique_abbrev(one, DEFAULT_ABBREV));
	if (!fast_backward && !fast_forward)
		strbuf_addch(&sb, '.');
	strbuf_addf(&sb, "%s", find_unique_abbrev(two, DEFAULT_ABBREV));
	if (message)
329
		strbuf_addf(&sb, " %s%s\n", message, reset);
330
	else
331
		strbuf_addf(&sb, "%s:%s\n", fast_backward ? " (rewind)" : "", reset);
332 333
	fwrite(sb.buf, sb.len, 1, f);

334
	if (!message) /* only NULL if we succeeded in setting up the walk */
335
		print_submodule_summary(&rev, f, line_prefix, del, add, reset);
336
	if (left)
337
		clear_commit_marks(left, ~0);
338
	if (right)
339
		clear_commit_marks(right, ~0);
340

341 342
	strbuf_release(&sb);
}
343

344 345 346 347 348
void set_config_fetch_recurse_submodules(int value)
{
	config_fetch_recurse_submodules = value;
}

349 350
static int has_remote(const char *refname, const struct object_id *oid,
		      int flags, void *cb_data)
351 352 353 354 355 356 357 358 359 360
{
	return 1;
}

static int submodule_needs_pushing(const char *path, const unsigned char sha1[20])
{
	if (add_submodule_odb(path) || !lookup_commit_reference(sha1))
		return 0;

	if (for_each_remote_ref_submodule(path, has_remote, NULL) > 0) {
361
		struct child_process cp = CHILD_PROCESS_INIT;
362 363 364 365 366 367 368 369 370 371 372 373 374 375 376 377 378 379 380 381 382 383 384 385 386 387 388 389 390 391
		const char *argv[] = {"rev-list", NULL, "--not", "--remotes", "-n", "1" , NULL};
		struct strbuf buf = STRBUF_INIT;
		int needs_pushing = 0;

		argv[1] = sha1_to_hex(sha1);
		cp.argv = argv;
		cp.env = local_repo_env;
		cp.git_cmd = 1;
		cp.no_stdin = 1;
		cp.out = -1;
		cp.dir = path;
		if (start_command(&cp))
			die("Could not run 'git rev-list %s --not --remotes -n 1' command in submodule %s",
				sha1_to_hex(sha1), path);
		if (strbuf_read(&buf, cp.out, 41))
			needs_pushing = 1;
		finish_command(&cp);
		close(cp.out);
		strbuf_release(&buf);
		return needs_pushing;
	}

	return 0;
}

static void collect_submodules_from_diff(struct diff_queue_struct *q,
					 struct diff_options *options,
					 void *data)
{
	int i;
392
	struct string_list *needs_pushing = data;
393 394 395 396 397

	for (i = 0; i < q->nr; i++) {
		struct diff_filepair *p = q->queue[i];
		if (!S_ISGITLINK(p->two->mode))
			continue;
398 399
		if (submodule_needs_pushing(p->two->path, p->two->sha1))
			string_list_insert(needs_pushing, p->two->path);
400 401 402
	}
}

403 404
static void find_unpushed_submodule_commits(struct commit *commit,
		struct string_list *needs_pushing)
405 406 407 408 409 410 411
{
	struct rev_info rev;

	init_revisions(&rev, NULL);
	rev.diffopt.output_format |= DIFF_FORMAT_CALLBACK;
	rev.diffopt.format_callback = collect_submodules_from_diff;
	rev.diffopt.format_callback_data = needs_pushing;
412
	diff_tree_combined_merge(commit, 1, &rev);
413 414
}

415 416
int find_unpushed_submodules(unsigned char new_sha1[20],
		const char *remotes_name, struct string_list *needs_pushing)
417 418 419 420 421 422
{
	struct rev_info rev;
	struct commit *commit;
	const char *argv[] = {NULL, NULL, "--not", "NULL", NULL};
	int argc = ARRAY_SIZE(argv) - 1;
	char *sha1_copy;
423

424 425 426 427 428 429 430 431 432 433 434
	struct strbuf remotes_arg = STRBUF_INIT;

	strbuf_addf(&remotes_arg, "--remotes=%s", remotes_name);
	init_revisions(&rev, NULL);
	sha1_copy = xstrdup(sha1_to_hex(new_sha1));
	argv[1] = sha1_copy;
	argv[3] = remotes_arg.buf;
	setup_revisions(argc, argv, &rev, NULL);
	if (prepare_revision_walk(&rev))
		die("revision walk setup failed");

435 436
	while ((commit = get_revision(&rev)) != NULL)
		find_unpushed_submodule_commits(commit, needs_pushing);
437

438
	reset_revision_walk();
439 440 441
	free(sha1_copy);
	strbuf_release(&remotes_arg);

442
	return needs_pushing->nr;
443 444
}

445 446 447 448 449 450
static int push_submodule(const char *path)
{
	if (add_submodule_odb(path))
		return 1;

	if (for_each_remote_ref_submodule(path, has_remote, NULL) > 0) {
451
		struct child_process cp = CHILD_PROCESS_INIT;
452 453 454 455 456 457 458 459 460 461 462 463 464 465 466 467 468 469
		const char *argv[] = {"push", NULL};

		cp.argv = argv;
		cp.env = local_repo_env;
		cp.git_cmd = 1;
		cp.no_stdin = 1;
		cp.dir = path;
		if (run_command(&cp))
			return 0;
		close(cp.out);
	}

	return 1;
}

int push_unpushed_submodules(unsigned char new_sha1[20], const char *remotes_name)
{
	int i, ret = 1;
470
	struct string_list needs_pushing = STRING_LIST_INIT_DUP;
471 472 473 474 475 476 477 478 479 480 481 482 483 484 485 486 487 488

	if (!find_unpushed_submodules(new_sha1, remotes_name, &needs_pushing))
		return 1;

	for (i = 0; i < needs_pushing.nr; i++) {
		const char *path = needs_pushing.items[i].string;
		fprintf(stderr, "Pushing submodule '%s'\n", path);
		if (!push_submodule(path)) {
			fprintf(stderr, "Unable to push submodule '%s'\n", path);
			ret = 0;
		}
	}

	string_list_clear(&needs_pushing, 0);

	return ret;
}

489 490 491 492 493 494
static int is_submodule_commit_present(const char *path, unsigned char sha1[20])
{
	int is_present = 0;
	if (!add_submodule_odb(path) && lookup_commit_reference(sha1)) {
		/* Even if the submodule is checked out and the commit is
		 * present, make sure it is reachable from a ref. */
495
		struct child_process cp = CHILD_PROCESS_INIT;
496 497 498 499 500 501 502 503 504
		const char *argv[] = {"rev-list", "-n", "1", NULL, "--not", "--all", NULL};
		struct strbuf buf = STRBUF_INIT;

		argv[3] = sha1_to_hex(sha1);
		cp.argv = argv;
		cp.env = local_repo_env;
		cp.git_cmd = 1;
		cp.no_stdin = 1;
		cp.dir = path;
J
Jeff King 已提交
505
		if (!capture_command(&cp, &buf, 1024) && !buf.len)
506 507 508 509 510 511 512
			is_present = 1;

		strbuf_release(&buf);
	}
	return is_present;
}

513 514 515 516 517 518 519 520 521 522 523 524 525 526 527 528 529
static void submodule_collect_changed_cb(struct diff_queue_struct *q,
					 struct diff_options *options,
					 void *data)
{
	int i;
	for (i = 0; i < q->nr; i++) {
		struct diff_filepair *p = q->queue[i];
		if (!S_ISGITLINK(p->two->mode))
			continue;

		if (S_ISGITLINK(p->one->mode)) {
			/* NEEDSWORK: We should honor the name configured in
			 * the .gitmodules file of the commit we are examining
			 * here to be able to correctly follow submodules
			 * being moved around. */
			struct string_list_item *path;
			path = unsorted_string_list_lookup(&changed_submodule_paths, p->two->path);
530
			if (!path && !is_submodule_commit_present(p->two->path, p->two->sha1))
531 532 533 534 535 536 537 538 539 540 541 542 543
				string_list_append(&changed_submodule_paths, xstrdup(p->two->path));
		} else {
			/* Submodule is new or was moved here */
			/* NEEDSWORK: When the .git directories of submodules
			 * live inside the superprojects .git directory some
			 * day we should fetch new submodules directly into
			 * that location too when config or options request
			 * that so they can be checked out from there. */
			continue;
		}
	}
}

544
static int add_sha1_to_array(const char *ref, const struct object_id *oid,
545 546
			     int flags, void *data)
{
547
	sha1_array_append(data, oid->hash);
548 549 550
	return 0;
}

551
void check_for_new_submodule_commits(unsigned char new_sha1[20])
552 553 554 555 556 557 558 559 560 561 562
{
	if (!initialized_fetch_ref_tips) {
		for_each_ref(add_sha1_to_array, &ref_tips_before_fetch);
		initialized_fetch_ref_tips = 1;
	}

	sha1_array_append(&ref_tips_after_fetch, new_sha1);
}

static void add_sha1_to_argv(const unsigned char sha1[20], void *data)
{
563
	argv_array_push(data, sha1_to_hex(sha1));
564 565 566
}

static void calculate_changed_submodule_paths(void)
567 568 569
{
	struct rev_info rev;
	struct commit *commit;
570
	struct argv_array argv = ARGV_ARRAY_INIT;
571

572
	/* No need to check if there are no submodules configured */
573
	if (!submodule_from_path(NULL, NULL))
574 575
		return;

576
	init_revisions(&rev, NULL);
577
	argv_array_push(&argv, "--"); /* argv[0] program name */
578 579
	sha1_array_for_each_unique(&ref_tips_after_fetch,
				   add_sha1_to_argv, &argv);
580
	argv_array_push(&argv, "--not");
581 582 583
	sha1_array_for_each_unique(&ref_tips_before_fetch,
				   add_sha1_to_argv, &argv);
	setup_revisions(argv.argc, argv.argv, &rev, NULL);
584 585 586 587 588 589 590 591 592 593 594 595
	if (prepare_revision_walk(&rev))
		die("revision walk setup failed");

	/*
	 * Collect all submodules (whether checked out or not) for which new
	 * commits have been recorded upstream in "changed_submodule_paths".
	 */
	while ((commit = get_revision(&rev))) {
		struct commit_list *parent = commit->parents;
		while (parent) {
			struct diff_options diff_opts;
			diff_setup(&diff_opts);
596
			DIFF_OPT_SET(&diff_opts, RECURSIVE);
597 598
			diff_opts.output_format |= DIFF_FORMAT_CALLBACK;
			diff_opts.format_callback = submodule_collect_changed_cb;
T
Thomas Rast 已提交
599
			diff_setup_done(&diff_opts);
B
brian m. carlson 已提交
600
			diff_tree_sha1(parent->item->object.oid.hash, commit->object.oid.hash, "", &diff_opts);
601 602 603 604 605
			diffcore_std(&diff_opts);
			diff_flush(&diff_opts);
			parent = parent->next;
		}
	}
606

607
	argv_array_clear(&argv);
608 609 610
	sha1_array_clear(&ref_tips_before_fetch);
	sha1_array_clear(&ref_tips_after_fetch);
	initialized_fetch_ref_tips = 0;
611 612
}

613
int fetch_populated_submodules(const struct argv_array *options,
614
			       const char *prefix, int command_line_option,
615
			       int quiet)
616
{
617
	int i, result = 0;
618
	struct child_process cp = CHILD_PROCESS_INIT;
619
	struct argv_array argv = ARGV_ARRAY_INIT;
620 621
	const char *work_tree = get_git_work_tree();
	if (!work_tree)
622
		goto out;
623

624 625
	if (read_cache() < 0)
		die("index file corrupt");
626

627 628 629 630 631
	argv_array_push(&argv, "fetch");
	for (i = 0; i < options->argc; i++)
		argv_array_push(&argv, options->argv[i]);
	argv_array_push(&argv, "--recurse-submodules-default");
	/* default value, "--submodule-prefix" and its value are added later */
632 633 634 635 636

	cp.env = local_repo_env;
	cp.git_cmd = 1;
	cp.no_stdin = 1;

637 638
	calculate_changed_submodule_paths();

639 640 641 642
	for (i = 0; i < active_nr; i++) {
		struct strbuf submodule_path = STRBUF_INIT;
		struct strbuf submodule_git_dir = STRBUF_INIT;
		struct strbuf submodule_prefix = STRBUF_INIT;
643
		const struct cache_entry *ce = active_cache[i];
644 645
		const char *git_dir, *default_argv;
		const struct submodule *submodule;
646 647 648 649

		if (!S_ISGITLINK(ce->ce_mode))
			continue;

650 651 652
		submodule = submodule_from_path(null_sha1, ce->name);
		if (!submodule)
			submodule = submodule_from_name(null_sha1, ce->name);
653

654
		default_argv = "yes";
655
		if (command_line_option == RECURSE_SUBMODULES_DEFAULT) {
656 657 658 659 660
			if (submodule &&
			    submodule->fetch_recurse !=
						RECURSE_SUBMODULES_NONE) {
				if (submodule->fetch_recurse ==
						RECURSE_SUBMODULES_OFF)
661
					continue;
662 663
				if (submodule->fetch_recurse ==
						RECURSE_SUBMODULES_ON_DEMAND) {
664 665 666 667
					if (!unsorted_string_list_lookup(&changed_submodule_paths, ce->name))
						continue;
					default_argv = "on-demand";
				}
668
			} else {
669 670
				if ((config_fetch_recurse_submodules == RECURSE_SUBMODULES_OFF) ||
				    gitmodules_is_unmerged)
671
					continue;
672 673 674 675 676
				if (config_fetch_recurse_submodules == RECURSE_SUBMODULES_ON_DEMAND) {
					if (!unsorted_string_list_lookup(&changed_submodule_paths, ce->name))
						continue;
					default_argv = "on-demand";
				}
677
			}
678 679 680 681
		} else if (command_line_option == RECURSE_SUBMODULES_ON_DEMAND) {
			if (!unsorted_string_list_lookup(&changed_submodule_paths, ce->name))
				continue;
			default_argv = "on-demand";
682 683
		}

684 685 686
		strbuf_addf(&submodule_path, "%s/%s", work_tree, ce->name);
		strbuf_addf(&submodule_git_dir, "%s/.git", submodule_path.buf);
		strbuf_addf(&submodule_prefix, "%s%s/", prefix, ce->name);
687
		git_dir = read_gitfile(submodule_git_dir.buf);
688 689 690 691 692 693
		if (!git_dir)
			git_dir = submodule_git_dir.buf;
		if (is_directory(git_dir)) {
			if (!quiet)
				printf("Fetching submodule %s%s\n", prefix, ce->name);
			cp.dir = submodule_path.buf;
694 695 696 697
			argv_array_push(&argv, default_argv);
			argv_array_push(&argv, "--submodule-prefix");
			argv_array_push(&argv, submodule_prefix.buf);
			cp.argv = argv.argv;
698 699
			if (run_command(&cp))
				result = 1;
700 701 702
			argv_array_pop(&argv);
			argv_array_pop(&argv);
			argv_array_pop(&argv);
703 704 705 706 707
		}
		strbuf_release(&submodule_path);
		strbuf_release(&submodule_git_dir);
		strbuf_release(&submodule_prefix);
	}
708
	argv_array_clear(&argv);
709 710
out:
	string_list_clear(&changed_submodule_paths, 1);
711 712 713
	return result;
}

714
unsigned is_submodule_modified(const char *path, int ignore_untracked)
715
{
716
	ssize_t len;
717
	struct child_process cp = CHILD_PROCESS_INIT;
718 719 720 721
	const char *argv[] = {
		"status",
		"--porcelain",
		NULL,
722
		NULL,
723 724
	};
	struct strbuf buf = STRBUF_INIT;
725 726
	unsigned dirty_submodule = 0;
	const char *line, *next_line;
727
	const char *git_dir;
728

729
	strbuf_addf(&buf, "%s/.git", path);
730
	git_dir = read_gitfile(buf.buf);
731 732 733
	if (!git_dir)
		git_dir = buf.buf;
	if (!is_directory(git_dir)) {
734 735 736 737 738 739 740
		strbuf_release(&buf);
		/* The submodule is not checked out, so it is not modified */
		return 0;

	}
	strbuf_reset(&buf);

741 742 743
	if (ignore_untracked)
		argv[2] = "-uno";

744
	cp.argv = argv;
745
	cp.env = local_repo_env;
746 747 748
	cp.git_cmd = 1;
	cp.no_stdin = 1;
	cp.out = -1;
749
	cp.dir = path;
750
	if (start_command(&cp))
751
		die("Could not run 'git status --porcelain' in submodule %s", path);
752 753

	len = strbuf_read(&buf, cp.out, 1024);
754 755 756 757 758 759 760 761
	line = buf.buf;
	while (len > 2) {
		if ((line[0] == '?') && (line[1] == '?')) {
			dirty_submodule |= DIRTY_SUBMODULE_UNTRACKED;
			if (dirty_submodule & DIRTY_SUBMODULE_MODIFIED)
				break;
		} else {
			dirty_submodule |= DIRTY_SUBMODULE_MODIFIED;
762 763
			if (ignore_untracked ||
			    (dirty_submodule & DIRTY_SUBMODULE_UNTRACKED))
764 765 766 767 768 769 770 771 772
				break;
		}
		next_line = strchr(line, '\n');
		if (!next_line)
			break;
		next_line++;
		len -= (next_line - line);
		line = next_line;
	}
773 774 775
	close(cp.out);

	if (finish_command(&cp))
776
		die("'git status --porcelain' failed in submodule %s", path);
777 778

	strbuf_release(&buf);
779
	return dirty_submodule;
780
}
781

782 783
int submodule_uses_gitfile(const char *path)
{
784
	struct child_process cp = CHILD_PROCESS_INIT;
785 786 787 788 789 790 791 792 793 794 795 796 797 798 799 800 801 802 803 804 805 806 807 808 809 810 811 812 813 814 815 816 817 818 819 820
	const char *argv[] = {
		"submodule",
		"foreach",
		"--quiet",
		"--recursive",
		"test -f .git",
		NULL,
	};
	struct strbuf buf = STRBUF_INIT;
	const char *git_dir;

	strbuf_addf(&buf, "%s/.git", path);
	git_dir = read_gitfile(buf.buf);
	if (!git_dir) {
		strbuf_release(&buf);
		return 0;
	}
	strbuf_release(&buf);

	/* Now test that all nested submodules use a gitfile too */
	cp.argv = argv;
	cp.env = local_repo_env;
	cp.git_cmd = 1;
	cp.no_stdin = 1;
	cp.no_stderr = 1;
	cp.no_stdout = 1;
	cp.dir = path;
	if (run_command(&cp))
		return 0;

	return 1;
}

int ok_to_remove_submodule(const char *path)
{
	ssize_t len;
821
	struct child_process cp = CHILD_PROCESS_INIT;
822 823 824 825 826 827 828 829 830 831
	const char *argv[] = {
		"status",
		"--porcelain",
		"-u",
		"--ignore-submodules=none",
		NULL,
	};
	struct strbuf buf = STRBUF_INIT;
	int ok_to_remove = 1;

832
	if (!file_exists(path) || is_empty_dir(path))
833 834 835 836 837 838 839 840 841 842 843 844 845 846 847 848 849 850 851 852 853 854 855 856 857 858
		return 1;

	if (!submodule_uses_gitfile(path))
		return 0;

	cp.argv = argv;
	cp.env = local_repo_env;
	cp.git_cmd = 1;
	cp.no_stdin = 1;
	cp.out = -1;
	cp.dir = path;
	if (start_command(&cp))
		die("Could not run 'git status --porcelain -uall --ignore-submodules=none' in submodule %s", path);

	len = strbuf_read(&buf, cp.out, 1024);
	if (len > 2)
		ok_to_remove = 0;
	close(cp.out);

	if (finish_command(&cp))
		die("'git status --porcelain -uall --ignore-submodules=none' failed in submodule %s", path);

	strbuf_release(&buf);
	return ok_to_remove;
}

859 860 861 862
static int find_first_merges(struct object_array *result, const char *path,
		struct commit *a, struct commit *b)
{
	int i, j;
863
	struct object_array merges = OBJECT_ARRAY_INIT;
864 865 866 867 868 869 870 871 872 873 874 875 876 877
	struct commit *commit;
	int contains_another;

	char merged_revision[42];
	const char *rev_args[] = { "rev-list", "--merges", "--ancestry-path",
				   "--all", merged_revision, NULL };
	struct rev_info revs;
	struct setup_revision_opt rev_opts;

	memset(result, 0, sizeof(struct object_array));
	memset(&rev_opts, 0, sizeof(rev_opts));

	/* get all revisions that merge commit a */
	snprintf(merged_revision, sizeof(merged_revision), "^%s",
878
			oid_to_hex(&a->object.oid));
879 880
	init_revisions(&revs, NULL);
	rev_opts.submodule = path;
881
	setup_revisions(ARRAY_SIZE(rev_args)-1, rev_args, &revs, &rev_opts);
882 883 884 885 886 887

	/* save all revisions from the above list that contain b */
	if (prepare_revision_walk(&revs))
		die("revision walk setup failed");
	while ((commit = get_revision(&revs)) != NULL) {
		struct object *o = &(commit->object);
888
		if (in_merge_bases(b, commit))
889 890
			add_object_array(o, NULL, &merges);
	}
891
	reset_revision_walk();
892 893 894 895 896 897 898 899 900 901 902

	/* Now we've got all merges that contain a and b. Prune all
	 * merges that contain another found merge and save them in
	 * result.
	 */
	for (i = 0; i < merges.nr; i++) {
		struct commit *m1 = (struct commit *) merges.objects[i].item;

		contains_another = 0;
		for (j = 0; j < merges.nr; j++) {
			struct commit *m2 = (struct commit *) merges.objects[j].item;
903
			if (i != j && in_merge_bases(m2, m1)) {
904 905 906 907 908 909
				contains_another = 1;
				break;
			}
		}

		if (!contains_another)
910
			add_object_array(merges.objects[i].item, NULL, result);
911 912 913 914 915 916 917 918 919 920
	}

	free(merges.objects);
	return result->nr;
}

static void print_commit(struct commit *commit)
{
	struct strbuf sb = STRBUF_INIT;
	struct pretty_print_context ctx = {0};
921
	ctx.date_mode.type = DATE_NORMAL;
922 923 924 925 926 927 928 929 930 931
	format_commit_message(commit, " %h: %m %s", &sb, &ctx);
	fprintf(stderr, "%s\n", sb.buf);
	strbuf_release(&sb);
}

#define MERGE_WARNING(path, msg) \
	warning("Failed to merge submodule %s (%s)", path, msg);

int merge_submodule(unsigned char result[20], const char *path,
		    const unsigned char base[20], const unsigned char a[20],
932
		    const unsigned char b[20], int search)
933 934 935 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
{
	struct commit *commit_base, *commit_a, *commit_b;
	int parent_count;
	struct object_array merges;

	int i;

	/* store a in result in case we fail */
	hashcpy(result, a);

	/* we can not handle deletion conflicts */
	if (is_null_sha1(base))
		return 0;
	if (is_null_sha1(a))
		return 0;
	if (is_null_sha1(b))
		return 0;

	if (add_submodule_odb(path)) {
		MERGE_WARNING(path, "not checked out");
		return 0;
	}

	if (!(commit_base = lookup_commit_reference(base)) ||
	    !(commit_a = lookup_commit_reference(a)) ||
	    !(commit_b = lookup_commit_reference(b))) {
		MERGE_WARNING(path, "commits not present");
		return 0;
	}

	/* check whether both changes are forward */
964 965
	if (!in_merge_bases(commit_base, commit_a) ||
	    !in_merge_bases(commit_base, commit_b)) {
966 967 968 969 970
		MERGE_WARNING(path, "commits don't follow merge-base");
		return 0;
	}

	/* Case #1: a is contained in b or vice versa */
971
	if (in_merge_bases(commit_a, commit_b)) {
972 973 974
		hashcpy(result, b);
		return 1;
	}
975
	if (in_merge_bases(commit_b, commit_a)) {
976 977 978 979 980 981 982 983 984 985 986
		hashcpy(result, a);
		return 1;
	}

	/*
	 * Case #2: There are one or more merges that contain a and b in
	 * the submodule. If there is only one, then present it as a
	 * suggestion to the user, but leave it marked unmerged so the
	 * user needs to confirm the resolution.
	 */

987 988 989 990
	/* Skip the search if makes no sense to the calling context.  */
	if (!search)
		return 0;

991 992 993 994 995 996 997 998 999 1000 1001 1002 1003 1004 1005 1006 1007 1008
	/* find commit which merges them */
	parent_count = find_first_merges(&merges, path, commit_a, commit_b);
	switch (parent_count) {
	case 0:
		MERGE_WARNING(path, "merge following commits not found");
		break;

	case 1:
		MERGE_WARNING(path, "not fast-forward");
		fprintf(stderr, "Found a possible merge resolution "
				"for the submodule:\n");
		print_commit((struct commit *) merges.objects[0].item);
		fprintf(stderr,
			"If this is correct simply add it to the index "
			"for example\n"
			"by using:\n\n"
			"  git update-index --cacheinfo 160000 %s \"%s\"\n\n"
			"which will accept this suggestion.\n",
1009
			oid_to_hex(&merges.objects[0].item->oid), path);
1010 1011 1012 1013 1014 1015 1016 1017 1018 1019 1020
		break;

	default:
		MERGE_WARNING(path, "multiple merges found");
		for (i = 0; i < merges.nr; i++)
			print_commit((struct commit *) merges.objects[i].item);
	}

	free(merges.objects);
	return 0;
}
1021 1022 1023 1024 1025 1026 1027 1028 1029 1030

/* Update gitfile and core.worktree setting to connect work tree and git dir */
void connect_work_tree_and_git_dir(const char *work_tree, const char *git_dir)
{
	struct strbuf file_name = STRBUF_INIT;
	struct strbuf rel_path = STRBUF_INIT;
	const char *real_work_tree = xstrdup(real_path(work_tree));

	/* Update gitfile */
	strbuf_addf(&file_name, "%s/.git", work_tree);
1031
	write_file(file_name.buf, "gitdir: %s",
1032
		   relative_path(git_dir, real_work_tree, &rel_path));
1033 1034 1035 1036 1037 1038 1039 1040 1041 1042 1043 1044 1045 1046

	/* Update core.worktree setting */
	strbuf_reset(&file_name);
	strbuf_addf(&file_name, "%s/config", git_dir);
	if (git_config_set_in_file(file_name.buf, "core.worktree",
				   relative_path(real_work_tree, git_dir,
						 &rel_path)))
		die(_("Could not set core.worktree in %s"),
		    file_name.buf);

	strbuf_release(&file_name);
	strbuf_release(&rel_path);
	free((void *)real_work_tree);
}