submodule--helper: initial clone learns retry logic
[git/debian.git] / builtin / submodule--helper.c
blob8d01fdd1f0fa8029ba1703b80790262a38a0b441
1 #include "builtin.h"
2 #include "cache.h"
3 #include "parse-options.h"
4 #include "quote.h"
5 #include "pathspec.h"
6 #include "dir.h"
7 #include "utf8.h"
8 #include "submodule.h"
9 #include "submodule-config.h"
10 #include "string-list.h"
11 #include "run-command.h"
12 #include "remote.h"
13 #include "refs.h"
14 #include "connect.h"
16 static char *get_default_remote(void)
18 char *dest = NULL, *ret;
19 unsigned char sha1[20];
20 struct strbuf sb = STRBUF_INIT;
21 const char *refname = resolve_ref_unsafe("HEAD", 0, sha1, NULL);
23 if (!refname)
24 die(_("No such ref: %s"), "HEAD");
26 /* detached HEAD */
27 if (!strcmp(refname, "HEAD"))
28 return xstrdup("origin");
30 if (!skip_prefix(refname, "refs/heads/", &refname))
31 die(_("Expecting a full ref name, got %s"), refname);
33 strbuf_addf(&sb, "branch.%s.remote", refname);
34 if (git_config_get_string(sb.buf, &dest))
35 ret = xstrdup("origin");
36 else
37 ret = dest;
39 strbuf_release(&sb);
40 return ret;
43 static int starts_with_dot_slash(const char *str)
45 return str[0] == '.' && is_dir_sep(str[1]);
48 static int starts_with_dot_dot_slash(const char *str)
50 return str[0] == '.' && str[1] == '.' && is_dir_sep(str[2]);
54 * Returns 1 if it was the last chop before ':'.
56 static int chop_last_dir(char **remoteurl, int is_relative)
58 char *rfind = find_last_dir_sep(*remoteurl);
59 if (rfind) {
60 *rfind = '\0';
61 return 0;
64 rfind = strrchr(*remoteurl, ':');
65 if (rfind) {
66 *rfind = '\0';
67 return 1;
70 if (is_relative || !strcmp(".", *remoteurl))
71 die(_("cannot strip one component off url '%s'"),
72 *remoteurl);
74 free(*remoteurl);
75 *remoteurl = xstrdup(".");
76 return 0;
80 * The `url` argument is the URL that navigates to the submodule origin
81 * repo. When relative, this URL is relative to the superproject origin
82 * URL repo. The `up_path` argument, if specified, is the relative
83 * path that navigates from the submodule working tree to the superproject
84 * working tree. Returns the origin URL of the submodule.
86 * Return either an absolute URL or filesystem path (if the superproject
87 * origin URL is an absolute URL or filesystem path, respectively) or a
88 * relative file system path (if the superproject origin URL is a relative
89 * file system path).
91 * When the output is a relative file system path, the path is either
92 * relative to the submodule working tree, if up_path is specified, or to
93 * the superproject working tree otherwise.
95 * NEEDSWORK: This works incorrectly on the domain and protocol part.
96 * remote_url url outcome expectation
97 * http://a.com/b ../c http://a.com/c as is
98 * http://a.com/b ../../c http://c error out
99 * http://a.com/b ../../../c http:/c error out
100 * http://a.com/b ../../../../c http:c error out
101 * http://a.com/b ../../../../../c .:c error out
102 * NEEDSWORK: Given how chop_last_dir() works, this function is broken
103 * when a local part has a colon in its path component, too.
105 static char *relative_url(const char *remote_url,
106 const char *url,
107 const char *up_path)
109 int is_relative = 0;
110 int colonsep = 0;
111 char *out;
112 char *remoteurl = xstrdup(remote_url);
113 struct strbuf sb = STRBUF_INIT;
114 size_t len = strlen(remoteurl);
116 if (is_dir_sep(remoteurl[len]))
117 remoteurl[len] = '\0';
119 if (!url_is_local_not_ssh(remoteurl) || is_absolute_path(remoteurl))
120 is_relative = 0;
121 else {
122 is_relative = 1;
124 * Prepend a './' to ensure all relative
125 * remoteurls start with './' or '../'
127 if (!starts_with_dot_slash(remoteurl) &&
128 !starts_with_dot_dot_slash(remoteurl)) {
129 strbuf_reset(&sb);
130 strbuf_addf(&sb, "./%s", remoteurl);
131 free(remoteurl);
132 remoteurl = strbuf_detach(&sb, NULL);
136 * When the url starts with '../', remove that and the
137 * last directory in remoteurl.
139 while (url) {
140 if (starts_with_dot_dot_slash(url)) {
141 url += 3;
142 colonsep |= chop_last_dir(&remoteurl, is_relative);
143 } else if (starts_with_dot_slash(url))
144 url += 2;
145 else
146 break;
148 strbuf_reset(&sb);
149 strbuf_addf(&sb, "%s%s%s", remoteurl, colonsep ? ":" : "/", url);
150 free(remoteurl);
152 if (starts_with_dot_slash(sb.buf))
153 out = xstrdup(sb.buf + 2);
154 else
155 out = xstrdup(sb.buf);
156 strbuf_reset(&sb);
158 if (!up_path || !is_relative)
159 return out;
161 strbuf_addf(&sb, "%s%s", up_path, out);
162 free(out);
163 return strbuf_detach(&sb, NULL);
166 static int resolve_relative_url(int argc, const char **argv, const char *prefix)
168 char *remoteurl = NULL;
169 char *remote = get_default_remote();
170 const char *up_path = NULL;
171 char *res;
172 const char *url;
173 struct strbuf sb = STRBUF_INIT;
175 if (argc != 2 && argc != 3)
176 die("resolve-relative-url only accepts one or two arguments");
178 url = argv[1];
179 strbuf_addf(&sb, "remote.%s.url", remote);
180 free(remote);
182 if (git_config_get_string(sb.buf, &remoteurl))
183 /* the repository is its own authoritative upstream */
184 remoteurl = xgetcwd();
186 if (argc == 3)
187 up_path = argv[2];
189 res = relative_url(remoteurl, url, up_path);
190 puts(res);
191 free(res);
192 free(remoteurl);
193 return 0;
196 static int resolve_relative_url_test(int argc, const char **argv, const char *prefix)
198 char *remoteurl, *res;
199 const char *up_path, *url;
201 if (argc != 4)
202 die("resolve-relative-url-test only accepts three arguments: <up_path> <remoteurl> <url>");
204 up_path = argv[1];
205 remoteurl = xstrdup(argv[2]);
206 url = argv[3];
208 if (!strcmp(up_path, "(null)"))
209 up_path = NULL;
211 res = relative_url(remoteurl, url, up_path);
212 puts(res);
213 free(res);
214 free(remoteurl);
215 return 0;
218 struct module_list {
219 const struct cache_entry **entries;
220 int alloc, nr;
222 #define MODULE_LIST_INIT { NULL, 0, 0 }
224 static int module_list_compute(int argc, const char **argv,
225 const char *prefix,
226 struct pathspec *pathspec,
227 struct module_list *list)
229 int i, result = 0;
230 char *ps_matched = NULL;
231 parse_pathspec(pathspec, 0,
232 PATHSPEC_PREFER_FULL |
233 PATHSPEC_STRIP_SUBMODULE_SLASH_CHEAP,
234 prefix, argv);
236 if (pathspec->nr)
237 ps_matched = xcalloc(pathspec->nr, 1);
239 if (read_cache() < 0)
240 die(_("index file corrupt"));
242 for (i = 0; i < active_nr; i++) {
243 const struct cache_entry *ce = active_cache[i];
245 if (!match_pathspec(pathspec, ce->name, ce_namelen(ce),
246 0, ps_matched, 1) ||
247 !S_ISGITLINK(ce->ce_mode))
248 continue;
250 ALLOC_GROW(list->entries, list->nr + 1, list->alloc);
251 list->entries[list->nr++] = ce;
252 while (i + 1 < active_nr &&
253 !strcmp(ce->name, active_cache[i + 1]->name))
255 * Skip entries with the same name in different stages
256 * to make sure an entry is returned only once.
258 i++;
261 if (ps_matched && report_path_error(ps_matched, pathspec, prefix))
262 result = -1;
264 free(ps_matched);
266 return result;
269 static int module_list(int argc, const char **argv, const char *prefix)
271 int i;
272 struct pathspec pathspec;
273 struct module_list list = MODULE_LIST_INIT;
275 struct option module_list_options[] = {
276 OPT_STRING(0, "prefix", &prefix,
277 N_("path"),
278 N_("alternative anchor for relative paths")),
279 OPT_END()
282 const char *const git_submodule_helper_usage[] = {
283 N_("git submodule--helper list [--prefix=<path>] [<path>...]"),
284 NULL
287 argc = parse_options(argc, argv, prefix, module_list_options,
288 git_submodule_helper_usage, 0);
290 if (module_list_compute(argc, argv, prefix, &pathspec, &list) < 0) {
291 printf("#unmatched\n");
292 return 1;
295 for (i = 0; i < list.nr; i++) {
296 const struct cache_entry *ce = list.entries[i];
298 if (ce_stage(ce))
299 printf("%06o %s U\t", ce->ce_mode, sha1_to_hex(null_sha1));
300 else
301 printf("%06o %s %d\t", ce->ce_mode, sha1_to_hex(ce->sha1), ce_stage(ce));
303 utf8_fprintf(stdout, "%s\n", ce->name);
305 return 0;
308 static void init_submodule(const char *path, const char *prefix, int quiet)
310 const struct submodule *sub;
311 struct strbuf sb = STRBUF_INIT;
312 char *upd = NULL, *url = NULL, *displaypath;
314 /* Only loads from .gitmodules, no overlay with .git/config */
315 gitmodules_config();
317 if (prefix) {
318 strbuf_addf(&sb, "%s%s", prefix, path);
319 displaypath = strbuf_detach(&sb, NULL);
320 } else
321 displaypath = xstrdup(path);
323 sub = submodule_from_path(null_sha1, path);
325 if (!sub)
326 die(_("No url found for submodule path '%s' in .gitmodules"),
327 displaypath);
330 * Copy url setting when it is not set yet.
331 * To look up the url in .git/config, we must not fall back to
332 * .gitmodules, so look it up directly.
334 strbuf_reset(&sb);
335 strbuf_addf(&sb, "submodule.%s.url", sub->name);
336 if (git_config_get_string(sb.buf, &url)) {
337 url = xstrdup(sub->url);
339 if (!url)
340 die(_("No url found for submodule path '%s' in .gitmodules"),
341 displaypath);
343 /* Possibly a url relative to parent */
344 if (starts_with_dot_dot_slash(url) ||
345 starts_with_dot_slash(url)) {
346 char *remoteurl, *relurl;
347 char *remote = get_default_remote();
348 struct strbuf remotesb = STRBUF_INIT;
349 strbuf_addf(&remotesb, "remote.%s.url", remote);
350 free(remote);
352 if (git_config_get_string(remotesb.buf, &remoteurl))
354 * The repository is its own
355 * authoritative upstream
357 remoteurl = xgetcwd();
358 relurl = relative_url(remoteurl, url, NULL);
359 strbuf_release(&remotesb);
360 free(remoteurl);
361 free(url);
362 url = relurl;
365 if (git_config_set_gently(sb.buf, url))
366 die(_("Failed to register url for submodule path '%s'"),
367 displaypath);
368 if (!quiet)
369 fprintf(stderr,
370 _("Submodule '%s' (%s) registered for path '%s'\n"),
371 sub->name, url, displaypath);
374 /* Copy "update" setting when it is not set yet */
375 strbuf_reset(&sb);
376 strbuf_addf(&sb, "submodule.%s.update", sub->name);
377 if (git_config_get_string(sb.buf, &upd) &&
378 sub->update_strategy.type != SM_UPDATE_UNSPECIFIED) {
379 if (sub->update_strategy.type == SM_UPDATE_COMMAND) {
380 fprintf(stderr, _("warning: command update mode suggested for submodule '%s'\n"),
381 sub->name);
382 upd = xstrdup("none");
383 } else
384 upd = xstrdup(submodule_strategy_to_string(&sub->update_strategy));
386 if (git_config_set_gently(sb.buf, upd))
387 die(_("Failed to register update mode for submodule path '%s'"), displaypath);
389 strbuf_release(&sb);
390 free(displaypath);
391 free(url);
392 free(upd);
395 static int module_init(int argc, const char **argv, const char *prefix)
397 struct pathspec pathspec;
398 struct module_list list = MODULE_LIST_INIT;
399 int quiet = 0;
400 int i;
402 struct option module_init_options[] = {
403 OPT_STRING(0, "prefix", &prefix,
404 N_("path"),
405 N_("alternative anchor for relative paths")),
406 OPT__QUIET(&quiet, N_("Suppress output for initializing a submodule")),
407 OPT_END()
410 const char *const git_submodule_helper_usage[] = {
411 N_("git submodule--helper init [<path>]"),
412 NULL
415 argc = parse_options(argc, argv, prefix, module_init_options,
416 git_submodule_helper_usage, 0);
418 if (module_list_compute(argc, argv, prefix, &pathspec, &list) < 0)
419 return 1;
421 for (i = 0; i < list.nr; i++)
422 init_submodule(list.entries[i]->name, prefix, quiet);
424 return 0;
427 static int module_name(int argc, const char **argv, const char *prefix)
429 const struct submodule *sub;
431 if (argc != 2)
432 usage(_("git submodule--helper name <path>"));
434 gitmodules_config();
435 sub = submodule_from_path(null_sha1, argv[1]);
437 if (!sub)
438 die(_("no submodule mapping found in .gitmodules for path '%s'"),
439 argv[1]);
441 printf("%s\n", sub->name);
443 return 0;
446 static int clone_submodule(const char *path, const char *gitdir, const char *url,
447 const char *depth, const char *reference, int quiet)
449 struct child_process cp;
450 child_process_init(&cp);
452 argv_array_push(&cp.args, "clone");
453 argv_array_push(&cp.args, "--no-checkout");
454 if (quiet)
455 argv_array_push(&cp.args, "--quiet");
456 if (depth && *depth)
457 argv_array_pushl(&cp.args, "--depth", depth, NULL);
458 if (reference && *reference)
459 argv_array_pushl(&cp.args, "--reference", reference, NULL);
460 if (gitdir && *gitdir)
461 argv_array_pushl(&cp.args, "--separate-git-dir", gitdir, NULL);
463 argv_array_push(&cp.args, url);
464 argv_array_push(&cp.args, path);
466 cp.git_cmd = 1;
467 prepare_submodule_repo_env(&cp.env_array);
468 cp.no_stdin = 1;
470 return run_command(&cp);
473 static int module_clone(int argc, const char **argv, const char *prefix)
475 const char *name = NULL, *url = NULL;
476 const char *reference = NULL, *depth = NULL;
477 int quiet = 0;
478 FILE *submodule_dot_git;
479 char *p, *path = NULL, *sm_gitdir;
480 struct strbuf rel_path = STRBUF_INIT;
481 struct strbuf sb = STRBUF_INIT;
483 struct option module_clone_options[] = {
484 OPT_STRING(0, "prefix", &prefix,
485 N_("path"),
486 N_("alternative anchor for relative paths")),
487 OPT_STRING(0, "path", &path,
488 N_("path"),
489 N_("where the new submodule will be cloned to")),
490 OPT_STRING(0, "name", &name,
491 N_("string"),
492 N_("name of the new submodule")),
493 OPT_STRING(0, "url", &url,
494 N_("string"),
495 N_("url where to clone the submodule from")),
496 OPT_STRING(0, "reference", &reference,
497 N_("string"),
498 N_("reference repository")),
499 OPT_STRING(0, "depth", &depth,
500 N_("string"),
501 N_("depth for shallow clones")),
502 OPT__QUIET(&quiet, "Suppress output for cloning a submodule"),
503 OPT_END()
506 const char *const git_submodule_helper_usage[] = {
507 N_("git submodule--helper clone [--prefix=<path>] [--quiet] "
508 "[--reference <repository>] [--name <name>] [--depth <depth>] "
509 "--url <url> --path <path>"),
510 NULL
513 argc = parse_options(argc, argv, prefix, module_clone_options,
514 git_submodule_helper_usage, 0);
516 if (argc || !url || !path || !*path)
517 usage_with_options(git_submodule_helper_usage,
518 module_clone_options);
520 strbuf_addf(&sb, "%s/modules/%s", get_git_dir(), name);
521 sm_gitdir = xstrdup(absolute_path(sb.buf));
522 strbuf_reset(&sb);
524 if (!is_absolute_path(path)) {
525 strbuf_addf(&sb, "%s/%s", get_git_work_tree(), path);
526 path = strbuf_detach(&sb, NULL);
527 } else
528 path = xstrdup(path);
530 if (!file_exists(sm_gitdir)) {
531 if (safe_create_leading_directories_const(sm_gitdir) < 0)
532 die(_("could not create directory '%s'"), sm_gitdir);
533 if (clone_submodule(path, sm_gitdir, url, depth, reference, quiet))
534 die(_("clone of '%s' into submodule path '%s' failed"),
535 url, path);
536 } else {
537 if (safe_create_leading_directories_const(path) < 0)
538 die(_("could not create directory '%s'"), path);
539 strbuf_addf(&sb, "%s/index", sm_gitdir);
540 unlink_or_warn(sb.buf);
541 strbuf_reset(&sb);
544 /* Write a .git file in the submodule to redirect to the superproject. */
545 strbuf_addf(&sb, "%s/.git", path);
546 if (safe_create_leading_directories_const(sb.buf) < 0)
547 die(_("could not create leading directories of '%s'"), sb.buf);
548 submodule_dot_git = fopen(sb.buf, "w");
549 if (!submodule_dot_git)
550 die_errno(_("cannot open file '%s'"), sb.buf);
552 fprintf_or_die(submodule_dot_git, "gitdir: %s\n",
553 relative_path(sm_gitdir, path, &rel_path));
554 if (fclose(submodule_dot_git))
555 die(_("could not close file %s"), sb.buf);
556 strbuf_reset(&sb);
557 strbuf_reset(&rel_path);
559 /* Redirect the worktree of the submodule in the superproject's config */
560 p = git_pathdup_submodule(path, "config");
561 if (!p)
562 die(_("could not get submodule directory for '%s'"), path);
563 git_config_set_in_file(p, "core.worktree",
564 relative_path(path, sm_gitdir, &rel_path));
565 strbuf_release(&sb);
566 strbuf_release(&rel_path);
567 free(sm_gitdir);
568 free(path);
569 free(p);
570 return 0;
573 struct submodule_update_clone {
574 /* index into 'list', the list of submodules to look into for cloning */
575 int current;
576 struct module_list list;
577 unsigned warn_if_uninitialized : 1;
579 /* update parameter passed via commandline */
580 struct submodule_update_strategy update;
582 /* configuration parameters which are passed on to the children */
583 int quiet;
584 int recommend_shallow;
585 const char *reference;
586 const char *depth;
587 const char *recursive_prefix;
588 const char *prefix;
590 /* Machine-readable status lines to be consumed by git-submodule.sh */
591 struct string_list projectlines;
593 /* If we want to stop as fast as possible and return an error */
594 unsigned quickstop : 1;
596 /* failed clones to be retried again */
597 const struct cache_entry **failed_clones;
598 int failed_clones_nr, failed_clones_alloc;
600 #define SUBMODULE_UPDATE_CLONE_INIT {0, MODULE_LIST_INIT, 0, \
601 SUBMODULE_UPDATE_STRATEGY_INIT, 0, -1, NULL, NULL, NULL, NULL, \
602 STRING_LIST_INIT_DUP, 0, NULL, 0, 0}
605 static void next_submodule_warn_missing(struct submodule_update_clone *suc,
606 struct strbuf *out, const char *displaypath)
609 * Only mention uninitialized submodules when their
610 * paths have been specified.
612 if (suc->warn_if_uninitialized) {
613 strbuf_addf(out,
614 _("Submodule path '%s' not initialized"),
615 displaypath);
616 strbuf_addch(out, '\n');
617 strbuf_addstr(out,
618 _("Maybe you want to use 'update --init'?"));
619 strbuf_addch(out, '\n');
624 * Determine whether 'ce' needs to be cloned. If so, prepare the 'child' to
625 * run the clone. Returns 1 if 'ce' needs to be cloned, 0 otherwise.
627 static int prepare_to_clone_next_submodule(const struct cache_entry *ce,
628 struct child_process *child,
629 struct submodule_update_clone *suc,
630 struct strbuf *out)
632 const struct submodule *sub = NULL;
633 struct strbuf displaypath_sb = STRBUF_INIT;
634 struct strbuf sb = STRBUF_INIT;
635 const char *displaypath = NULL;
636 char *url = NULL;
637 int needs_cloning = 0;
639 if (ce_stage(ce)) {
640 if (suc->recursive_prefix)
641 strbuf_addf(&sb, "%s/%s", suc->recursive_prefix, ce->name);
642 else
643 strbuf_addf(&sb, "%s", ce->name);
644 strbuf_addf(out, _("Skipping unmerged submodule %s"), sb.buf);
645 strbuf_addch(out, '\n');
646 goto cleanup;
649 sub = submodule_from_path(null_sha1, ce->name);
651 if (suc->recursive_prefix)
652 displaypath = relative_path(suc->recursive_prefix,
653 ce->name, &displaypath_sb);
654 else
655 displaypath = ce->name;
657 if (!sub) {
658 next_submodule_warn_missing(suc, out, displaypath);
659 goto cleanup;
662 if (suc->update.type == SM_UPDATE_NONE
663 || (suc->update.type == SM_UPDATE_UNSPECIFIED
664 && sub->update_strategy.type == SM_UPDATE_NONE)) {
665 strbuf_addf(out, _("Skipping submodule '%s'"), displaypath);
666 strbuf_addch(out, '\n');
667 goto cleanup;
671 * Looking up the url in .git/config.
672 * We must not fall back to .gitmodules as we only want
673 * to process configured submodules.
675 strbuf_reset(&sb);
676 strbuf_addf(&sb, "submodule.%s.url", sub->name);
677 git_config_get_string(sb.buf, &url);
678 if (!url) {
679 next_submodule_warn_missing(suc, out, displaypath);
680 goto cleanup;
683 strbuf_reset(&sb);
684 strbuf_addf(&sb, "%s/.git", ce->name);
685 needs_cloning = !file_exists(sb.buf);
687 strbuf_reset(&sb);
688 strbuf_addf(&sb, "%06o %s %d %d\t%s\n", ce->ce_mode,
689 sha1_to_hex(ce->sha1), ce_stage(ce),
690 needs_cloning, ce->name);
691 string_list_append(&suc->projectlines, sb.buf);
693 if (!needs_cloning)
694 goto cleanup;
696 child->git_cmd = 1;
697 child->no_stdin = 1;
698 child->stdout_to_stderr = 1;
699 child->err = -1;
700 argv_array_push(&child->args, "submodule--helper");
701 argv_array_push(&child->args, "clone");
702 if (suc->quiet)
703 argv_array_push(&child->args, "--quiet");
704 if (suc->prefix)
705 argv_array_pushl(&child->args, "--prefix", suc->prefix, NULL);
706 if (suc->recommend_shallow && sub->recommend_shallow == 1)
707 argv_array_push(&child->args, "--depth=1");
708 argv_array_pushl(&child->args, "--path", sub->path, NULL);
709 argv_array_pushl(&child->args, "--name", sub->name, NULL);
710 argv_array_pushl(&child->args, "--url", url, NULL);
711 if (suc->reference)
712 argv_array_push(&child->args, suc->reference);
713 if (suc->depth)
714 argv_array_push(&child->args, suc->depth);
716 cleanup:
717 free(url);
718 strbuf_reset(&displaypath_sb);
719 strbuf_reset(&sb);
721 return needs_cloning;
724 static int update_clone_get_next_task(struct child_process *child,
725 struct strbuf *err,
726 void *suc_cb,
727 void **idx_task_cb)
729 struct submodule_update_clone *suc = suc_cb;
730 const struct cache_entry *ce;
731 int index;
733 for (; suc->current < suc->list.nr; suc->current++) {
734 ce = suc->list.entries[suc->current];
735 if (prepare_to_clone_next_submodule(ce, child, suc, err)) {
736 int *p = xmalloc(sizeof(*p));
737 *p = suc->current;
738 *idx_task_cb = p;
739 suc->current++;
740 return 1;
745 * The loop above tried cloning each submodule once, now try the
746 * stragglers again, which we can imagine as an extension of the
747 * entry list.
749 index = suc->current - suc->list.nr;
750 if (index < suc->failed_clones_nr) {
751 int *p;
752 ce = suc->failed_clones[index];
753 if (!prepare_to_clone_next_submodule(ce, child, suc, err))
754 die("BUG: ce was a submodule before?");
755 p = xmalloc(sizeof(*p));
756 *p = suc->current;
757 *idx_task_cb = p;
758 suc->current ++;
759 return 1;
762 return 0;
765 static int update_clone_start_failure(struct strbuf *err,
766 void *suc_cb,
767 void *idx_task_cb)
769 struct submodule_update_clone *suc = suc_cb;
770 suc->quickstop = 1;
771 return 1;
774 static int update_clone_task_finished(int result,
775 struct strbuf *err,
776 void *suc_cb,
777 void *idx_task_cb)
779 const struct cache_entry *ce;
780 struct submodule_update_clone *suc = suc_cb;
782 int *idxP = *(int**)idx_task_cb;
783 int idx = *idxP;
784 free(idxP);
786 if (!result)
787 return 0;
789 if (idx < suc->list.nr) {
790 ce = suc->list.entries[idx];
791 strbuf_addf(err, _("Failed to clone '%s'. Retry scheduled"),
792 ce->name);
793 strbuf_addch(err, '\n');
794 ALLOC_GROW(suc->failed_clones,
795 suc->failed_clones_nr + 1,
796 suc->failed_clones_alloc);
797 suc->failed_clones[suc->failed_clones_nr++] = ce;
798 return 0;
799 } else {
800 idx = suc->current - suc->list.nr;
801 ce = suc->failed_clones[idx];
802 strbuf_addf(err, _("Failed to clone '%s' a second time, aborting"),
803 ce->name);
804 strbuf_addch(err, '\n');
805 suc->quickstop = 1;
806 return 1;
809 return 0;
812 static int update_clone(int argc, const char **argv, const char *prefix)
814 const char *update = NULL;
815 int max_jobs = -1;
816 struct string_list_item *item;
817 struct pathspec pathspec;
818 struct submodule_update_clone suc = SUBMODULE_UPDATE_CLONE_INIT;
820 struct option module_update_clone_options[] = {
821 OPT_STRING(0, "prefix", &prefix,
822 N_("path"),
823 N_("path into the working tree")),
824 OPT_STRING(0, "recursive-prefix", &suc.recursive_prefix,
825 N_("path"),
826 N_("path into the working tree, across nested "
827 "submodule boundaries")),
828 OPT_STRING(0, "update", &update,
829 N_("string"),
830 N_("rebase, merge, checkout or none")),
831 OPT_STRING(0, "reference", &suc.reference, N_("repo"),
832 N_("reference repository")),
833 OPT_STRING(0, "depth", &suc.depth, "<depth>",
834 N_("Create a shallow clone truncated to the "
835 "specified number of revisions")),
836 OPT_INTEGER('j', "jobs", &max_jobs,
837 N_("parallel jobs")),
838 OPT_BOOL(0, "recommend-shallow", &suc.recommend_shallow,
839 N_("whether the initial clone should follow the shallow recommendation")),
840 OPT__QUIET(&suc.quiet, N_("don't print cloning progress")),
841 OPT_END()
844 const char *const git_submodule_helper_usage[] = {
845 N_("git submodule--helper update_clone [--prefix=<path>] [<path>...]"),
846 NULL
848 suc.prefix = prefix;
850 argc = parse_options(argc, argv, prefix, module_update_clone_options,
851 git_submodule_helper_usage, 0);
853 if (update)
854 if (parse_submodule_update_strategy(update, &suc.update) < 0)
855 die(_("bad value for update parameter"));
857 if (module_list_compute(argc, argv, prefix, &pathspec, &suc.list) < 0)
858 return 1;
860 if (pathspec.nr)
861 suc.warn_if_uninitialized = 1;
863 /* Overlay the parsed .gitmodules file with .git/config */
864 gitmodules_config();
865 git_config(submodule_config, NULL);
867 if (max_jobs < 0)
868 max_jobs = parallel_submodules();
870 run_processes_parallel(max_jobs,
871 update_clone_get_next_task,
872 update_clone_start_failure,
873 update_clone_task_finished,
874 &suc);
877 * We saved the output and put it out all at once now.
878 * That means:
879 * - the listener does not have to interleave their (checkout)
880 * work with our fetching. The writes involved in a
881 * checkout involve more straightforward sequential I/O.
882 * - the listener can avoid doing any work if fetching failed.
884 if (suc.quickstop)
885 return 1;
887 for_each_string_list_item(item, &suc.projectlines)
888 utf8_fprintf(stdout, "%s", item->string);
890 return 0;
893 struct cmd_struct {
894 const char *cmd;
895 int (*fn)(int, const char **, const char *);
898 static struct cmd_struct commands[] = {
899 {"list", module_list},
900 {"name", module_name},
901 {"clone", module_clone},
902 {"update-clone", update_clone},
903 {"resolve-relative-url", resolve_relative_url},
904 {"resolve-relative-url-test", resolve_relative_url_test},
905 {"init", module_init}
908 int cmd_submodule__helper(int argc, const char **argv, const char *prefix)
910 int i;
911 if (argc < 2)
912 die(_("submodule--helper subcommand must be "
913 "called with a subcommand"));
915 for (i = 0; i < ARRAY_SIZE(commands); i++)
916 if (!strcmp(argv[1], commands[i].cmd))
917 return commands[i].fn(argc - 1, argv + 1, prefix);
919 die(_("'%s' is not a valid submodule--helper "
920 "subcommand"), argv[1]);