submodule.c 29.3 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
	const char *git_dir;
126

127
	strbuf_addf(&objects_directory, "%s/.git", path);
128
	git_dir = read_gitfile(objects_directory.buf);
129 130 131 132 133
	if (git_dir) {
		strbuf_reset(&objects_directory);
		strbuf_addstr(&objects_directory, git_dir);
	}
	strbuf_addstr(&objects_directory, "/objects/");
J
Jens Lehmann 已提交
134 135 136 137
	if (!is_directory(objects_directory.buf)) {
		ret = -1;
		goto done;
	}
138 139 140 141 142
	/* avoid adding it twice */
	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 已提交
143
			goto done;
144 145 146 147 148 149 150 151 152

	alt_odb = xmalloc(objects_directory.len + 42 + sizeof(*alt_odb));
	alt_odb->next = alt_odb_list;
	strcpy(alt_odb->base, objects_directory.buf);
	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;
153 154 155

	/* add possible alternates from the submodule */
	read_info_alternates(objects_directory.buf, 0);
156
	prepare_alt_odb();
J
Jens Lehmann 已提交
157 158 159
done:
	strbuf_release(&objects_directory);
	return ret;
160 161
}

162 163 164
void set_diffopt_flags_from_submodule_config(struct diff_options *diffopt,
					     const char *path)
{
165 166 167 168
	const struct submodule *submodule = submodule_from_path(null_sha1, path);
	if (submodule) {
		if (submodule->ignore)
			handle_ignore_submodules_arg(diffopt, submodule->ignore);
169 170
		else if (gitmodules_is_unmerged)
			DIFF_OPT_SET(diffopt, IGNORE_SUBMODULES);
171 172 173
	}
}

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

void gitmodules_config(void)
{
	const char *work_tree = get_git_work_tree();
	if (work_tree) {
		struct strbuf gitmodules_path = STRBUF_INIT;
190
		int pos;
191 192
		strbuf_addstr(&gitmodules_path, work_tree);
		strbuf_addstr(&gitmodules_path, "/.gitmodules");
193 194 195 196 197 198 199 200 201 202 203
		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;
			}
204 205 206 207 208
		} 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;
209 210 211 212
		}

		if (!gitmodules_is_unmerged)
			git_config_from_file(submodule_config, gitmodules_path.buf, NULL);
213 214 215 216
		strbuf_release(&gitmodules_path);
	}
}

217 218 219
void handle_ignore_submodules_arg(struct diff_options *diffopt,
				  const char *arg)
{
220 221 222 223
	DIFF_OPT_CLR(diffopt, IGNORE_SUBMODULES);
	DIFF_OPT_CLR(diffopt, IGNORE_UNTRACKED_IN_SUBMODULES);
	DIFF_OPT_CLR(diffopt, IGNORE_DIRTY_SUBMODULES);

224 225 226 227 228 229
	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);
230
	else if (strcmp(arg, "none"))
231 232 233
		die("bad --ignore-submodules argument: %s", arg);
}

234 235 236 237 238 239 240 241 242 243 244 245 246
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);
247
	merge_bases = get_merge_bases(left, right);
248 249 250 251 252 253 254 255 256 257 258 259 260 261 262
	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,
			sha1_to_hex(list->item->object.sha1));
	}
	return prepare_revision_walk(rev);
}

static void print_submodule_summary(struct rev_info *rev, FILE *f,
263
		const char *line_prefix,
264 265 266 267 268 269 270 271 272
		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;
273
		ctx.output_encoding = get_log_output_encoding();
274
		strbuf_setlen(&sb, 0);
275
		strbuf_addstr(&sb, line_prefix);
276 277 278 279 280 281 282 283 284 285 286 287 288 289 290
		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);
}

291
void show_submodule_summary(FILE *f, const char *path,
292
		const char *line_prefix,
293
		unsigned char one[20], unsigned char two[20],
294
		unsigned dirty_submodule, const char *meta,
295 296 297
		const char *del, const char *add, const char *reset)
{
	struct rev_info rev;
298
	struct commit *left = NULL, *right = NULL;
299 300 301 302 303 304 305 306 307 308 309 310 311
	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)";
312 313
	else if (prepare_submodule_summary(&rev, path, left, right,
					   &fast_forward, &fast_backward))
314
		message = "(revision walker failed)";
315

316
	if (dirty_submodule & DIRTY_SUBMODULE_UNTRACKED)
317 318
		fprintf(f, "%sSubmodule %s contains untracked content\n",
			line_prefix, path);
319
	if (dirty_submodule & DIRTY_SUBMODULE_MODIFIED)
320 321
		fprintf(f, "%sSubmodule %s contains modified content\n",
			line_prefix, path);
322 323 324 325 326 327

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

328
	strbuf_addf(&sb, "%s%sSubmodule %s %s..", line_prefix, meta, path,
329 330 331 332 333
			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)
334
		strbuf_addf(&sb, " %s%s\n", message, reset);
335
	else
336
		strbuf_addf(&sb, "%s:%s\n", fast_backward ? " (rewind)" : "", reset);
337 338
	fwrite(sb.buf, sb.len, 1, f);

339
	if (!message) /* only NULL if we succeeded in setting up the walk */
340
		print_submodule_summary(&rev, f, line_prefix, del, add, reset);
341
	if (left)
342
		clear_commit_marks(left, ~0);
343
	if (right)
344
		clear_commit_marks(right, ~0);
345

346 347
	strbuf_release(&sb);
}
348

349 350 351 352 353
void set_config_fetch_recurse_submodules(int value)
{
	config_fetch_recurse_submodules = value;
}

354 355
static int has_remote(const char *refname, const struct object_id *oid,
		      int flags, void *cb_data)
356 357 358 359 360 361 362 363 364 365
{
	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) {
366
		struct child_process cp = CHILD_PROCESS_INIT;
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 392 393 394 395 396
		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;
397
	struct string_list *needs_pushing = data;
398 399 400 401 402

	for (i = 0; i < q->nr; i++) {
		struct diff_filepair *p = q->queue[i];
		if (!S_ISGITLINK(p->two->mode))
			continue;
403 404
		if (submodule_needs_pushing(p->two->path, p->two->sha1))
			string_list_insert(needs_pushing, p->two->path);
405 406 407
	}
}

408 409
static void find_unpushed_submodule_commits(struct commit *commit,
		struct string_list *needs_pushing)
410 411 412 413 414 415 416
{
	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;
417
	diff_tree_combined_merge(commit, 1, &rev);
418 419
}

420 421
int find_unpushed_submodules(unsigned char new_sha1[20],
		const char *remotes_name, struct string_list *needs_pushing)
422 423 424 425 426 427
{
	struct rev_info rev;
	struct commit *commit;
	const char *argv[] = {NULL, NULL, "--not", "NULL", NULL};
	int argc = ARRAY_SIZE(argv) - 1;
	char *sha1_copy;
428

429 430 431 432 433 434 435 436 437 438 439
	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");

440 441
	while ((commit = get_revision(&rev)) != NULL)
		find_unpushed_submodule_commits(commit, needs_pushing);
442

443
	reset_revision_walk();
444 445 446
	free(sha1_copy);
	strbuf_release(&remotes_arg);

447
	return needs_pushing->nr;
448 449
}

450 451 452 453 454 455
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) {
456
		struct child_process cp = CHILD_PROCESS_INIT;
457 458 459 460 461 462 463 464 465 466 467 468 469 470 471 472 473 474
		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;
475
	struct string_list needs_pushing = STRING_LIST_INIT_DUP;
476 477 478 479 480 481 482 483 484 485 486 487 488 489 490 491 492 493

	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;
}

494 495 496 497 498 499
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. */
500
		struct child_process cp = CHILD_PROCESS_INIT;
501 502 503 504 505 506 507 508 509
		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 已提交
510
		if (!capture_command(&cp, &buf, 1024) && !buf.len)
511 512 513 514 515 516 517
			is_present = 1;

		strbuf_release(&buf);
	}
	return is_present;
}

518 519 520 521 522 523 524 525 526 527 528 529 530 531 532 533 534
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);
535
			if (!path && !is_submodule_commit_present(p->two->path, p->two->sha1))
536 537 538 539 540 541 542 543 544 545 546 547 548
				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;
		}
	}
}

549
static int add_sha1_to_array(const char *ref, const struct object_id *oid,
550 551
			     int flags, void *data)
{
552
	sha1_array_append(data, oid->hash);
553 554 555
	return 0;
}

556
void check_for_new_submodule_commits(unsigned char new_sha1[20])
557 558 559 560 561 562 563 564 565 566 567
{
	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)
{
568
	argv_array_push(data, sha1_to_hex(sha1));
569 570 571
}

static void calculate_changed_submodule_paths(void)
572 573 574
{
	struct rev_info rev;
	struct commit *commit;
575
	struct argv_array argv = ARGV_ARRAY_INIT;
576

577
	/* No need to check if there are no submodules configured */
578
	if (!submodule_from_path(NULL, NULL))
579 580
		return;

581
	init_revisions(&rev, NULL);
582
	argv_array_push(&argv, "--"); /* argv[0] program name */
583 584
	sha1_array_for_each_unique(&ref_tips_after_fetch,
				   add_sha1_to_argv, &argv);
585
	argv_array_push(&argv, "--not");
586 587 588
	sha1_array_for_each_unique(&ref_tips_before_fetch,
				   add_sha1_to_argv, &argv);
	setup_revisions(argv.argc, argv.argv, &rev, NULL);
589 590 591 592 593 594 595 596 597 598 599 600
	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);
601
			DIFF_OPT_SET(&diff_opts, RECURSIVE);
602 603
			diff_opts.output_format |= DIFF_FORMAT_CALLBACK;
			diff_opts.format_callback = submodule_collect_changed_cb;
T
Thomas Rast 已提交
604
			diff_setup_done(&diff_opts);
605 606 607 608 609 610
			diff_tree_sha1(parent->item->object.sha1, commit->object.sha1, "", &diff_opts);
			diffcore_std(&diff_opts);
			diff_flush(&diff_opts);
			parent = parent->next;
		}
	}
611

612
	argv_array_clear(&argv);
613 614 615
	sha1_array_clear(&ref_tips_before_fetch);
	sha1_array_clear(&ref_tips_after_fetch);
	initialized_fetch_ref_tips = 0;
616 617
}

618
int fetch_populated_submodules(const struct argv_array *options,
619
			       const char *prefix, int command_line_option,
620
			       int quiet)
621
{
622
	int i, result = 0;
623
	struct child_process cp = CHILD_PROCESS_INIT;
624
	struct argv_array argv = ARGV_ARRAY_INIT;
625 626
	const char *work_tree = get_git_work_tree();
	if (!work_tree)
627
		goto out;
628

629 630
	if (read_cache() < 0)
		die("index file corrupt");
631

632 633 634 635 636
	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 */
637 638 639 640 641

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

642 643
	calculate_changed_submodule_paths();

644 645 646 647
	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;
648
		const struct cache_entry *ce = active_cache[i];
649 650
		const char *git_dir, *default_argv;
		const struct submodule *submodule;
651 652 653 654

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

655 656 657
		submodule = submodule_from_path(null_sha1, ce->name);
		if (!submodule)
			submodule = submodule_from_name(null_sha1, ce->name);
658

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

689 690 691
		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);
692
		git_dir = read_gitfile(submodule_git_dir.buf);
693 694 695 696 697 698
		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;
699 700 701 702
			argv_array_push(&argv, default_argv);
			argv_array_push(&argv, "--submodule-prefix");
			argv_array_push(&argv, submodule_prefix.buf);
			cp.argv = argv.argv;
703 704
			if (run_command(&cp))
				result = 1;
705 706 707
			argv_array_pop(&argv);
			argv_array_pop(&argv);
			argv_array_pop(&argv);
708 709 710 711 712
		}
		strbuf_release(&submodule_path);
		strbuf_release(&submodule_git_dir);
		strbuf_release(&submodule_prefix);
	}
713
	argv_array_clear(&argv);
714 715
out:
	string_list_clear(&changed_submodule_paths, 1);
716 717 718
	return result;
}

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

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

	}
	strbuf_reset(&buf);

746 747 748
	if (ignore_untracked)
		argv[2] = "-uno";

749
	cp.argv = argv;
750
	cp.env = local_repo_env;
751 752 753
	cp.git_cmd = 1;
	cp.no_stdin = 1;
	cp.out = -1;
754
	cp.dir = path;
755
	if (start_command(&cp))
756
		die("Could not run 'git status --porcelain' in submodule %s", path);
757 758

	len = strbuf_read(&buf, cp.out, 1024);
759 760 761 762 763 764 765 766
	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;
767 768
			if (ignore_untracked ||
			    (dirty_submodule & DIRTY_SUBMODULE_UNTRACKED))
769 770 771 772 773 774 775 776 777
				break;
		}
		next_line = strchr(line, '\n');
		if (!next_line)
			break;
		next_line++;
		len -= (next_line - line);
		line = next_line;
	}
778 779 780
	close(cp.out);

	if (finish_command(&cp))
781
		die("'git status --porcelain' failed in submodule %s", path);
782 783

	strbuf_release(&buf);
784
	return dirty_submodule;
785
}
786

787 788
int submodule_uses_gitfile(const char *path)
{
789
	struct child_process cp = CHILD_PROCESS_INIT;
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 821 822 823 824 825
	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;
826
	struct child_process cp = CHILD_PROCESS_INIT;
827 828 829 830 831 832 833 834 835 836
	const char *argv[] = {
		"status",
		"--porcelain",
		"-u",
		"--ignore-submodules=none",
		NULL,
	};
	struct strbuf buf = STRBUF_INIT;
	int ok_to_remove = 1;

837
	if (!file_exists(path) || is_empty_dir(path))
838 839 840 841 842 843 844 845 846 847 848 849 850 851 852 853 854 855 856 857 858 859 860 861 862 863
		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;
}

864 865 866 867
static int find_first_merges(struct object_array *result, const char *path,
		struct commit *a, struct commit *b)
{
	int i, j;
868
	struct object_array merges = OBJECT_ARRAY_INIT;
869 870 871 872 873 874 875 876 877 878 879 880 881 882 883 884 885
	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",
			sha1_to_hex(a->object.sha1));
	init_revisions(&revs, NULL);
	rev_opts.submodule = path;
886
	setup_revisions(ARRAY_SIZE(rev_args)-1, rev_args, &revs, &rev_opts);
887 888 889 890 891 892

	/* 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);
893
		if (in_merge_bases(b, commit))
894 895
			add_object_array(o, NULL, &merges);
	}
896
	reset_revision_walk();
897 898 899 900 901 902 903 904 905 906 907

	/* 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;
908
			if (i != j && in_merge_bases(m2, m1)) {
909 910 911 912 913 914
				contains_another = 1;
				break;
			}
		}

		if (!contains_another)
915
			add_object_array(merges.objects[i].item, NULL, result);
916 917 918 919 920 921 922 923 924 925
	}

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

static void print_commit(struct commit *commit)
{
	struct strbuf sb = STRBUF_INIT;
	struct pretty_print_context ctx = {0};
926
	ctx.date_mode.type = DATE_NORMAL;
927 928 929 930 931 932 933 934 935 936
	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],
937
		    const unsigned char b[20], int search)
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
{
	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 */
969 970
	if (!in_merge_bases(commit_base, commit_a) ||
	    !in_merge_bases(commit_base, commit_b)) {
971 972 973 974 975
		MERGE_WARNING(path, "commits don't follow merge-base");
		return 0;
	}

	/* Case #1: a is contained in b or vice versa */
976
	if (in_merge_bases(commit_a, commit_b)) {
977 978 979
		hashcpy(result, b);
		return 1;
	}
980
	if (in_merge_bases(commit_b, commit_a)) {
981 982 983 984 985 986 987 988 989 990 991
		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.
	 */

992 993 994 995
	/* Skip the search if makes no sense to the calling context.  */
	if (!search)
		return 0;

996 997 998 999 1000 1001 1002 1003 1004 1005 1006 1007 1008 1009 1010 1011 1012 1013 1014 1015 1016 1017 1018 1019 1020 1021 1022 1023 1024 1025
	/* 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",
			sha1_to_hex(merges.objects[0].item->sha1), path);
		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;
}
1026 1027 1028 1029 1030 1031 1032 1033 1034 1035

/* 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);
1036
	write_file(file_name.buf, "gitdir: %s",
1037
		   relative_path(git_dir, real_work_tree, &rel_path));
1038 1039 1040 1041 1042 1043 1044 1045 1046 1047 1048 1049 1050 1051

	/* 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);
}