From: Junio C Hamano <gitster@pobox.com>
Date: Tue, 29 Jan 2019 20:47:53 +0000 (-0800)
Subject: Merge branch 'js/rebase-i-redo-exec'
X-Git-Tag: v2.21.0-rc0~72
X-Git-Url: https://git.lorimer.id.au/gitweb.git/diff_plain/d9d9ab0876e5ba82996852e7033b2fb29c970914?hp=-c

Merge branch 'js/rebase-i-redo-exec'

"git rebase -i" learned to re-execute a command given with 'exec'
to run after it failed the last time.

* js/rebase-i-redo-exec:
rebase: introduce a shortcut for --reschedule-failed-exec
rebase: add a config option to default to --reschedule-failed-exec
rebase: introduce --reschedule-failed-exec
---

d9d9ab0876e5ba82996852e7033b2fb29c970914
diff --combined Documentation/git-rebase.txt
index d284155cf3,98f60b2be0..4dd5853d6e
--- a/Documentation/git-rebase.txt
+++ b/Documentation/git-rebase.txt
@@@ -462,6 -462,12 +462,12 @@@ without an explicit `--interactive`
  +
  See also INCOMPATIBLE OPTIONS below.
  
+ -y <cmd>::
+ 	This is the same as passing `--reschedule-failed-exec` before
+ 	`-x <cmd>`, i.e. it appends the specified `exec` command and
+ 	turns on the mode where failed `exec` commands are automatically
+ 	rescheduled.
+ 
  --root::
  	Rebase all commits reachable from <branch>, instead of
  	limiting them with an <upstream>.  This allows you to rebase
@@@ -501,6 -507,11 +507,11 @@@ See also INCOMPATIBLE OPTIONS below
  	with care: the final stash application after a successful
  	rebase might result in non-trivial conflicts.
  
+ --reschedule-failed-exec::
+ --no-reschedule-failed-exec::
+ 	Automatically reschedule `exec` commands that failed. This only makes
+ 	sense in interactive mode (or when an `--exec` option was provided).
+ 
  INCOMPATIBLE OPTIONS
  --------------------
  
@@@ -570,9 -581,8 +581,9 @@@ it to keep commits that started empty
  Directory rename detection
  ~~~~~~~~~~~~~~~~~~~~~~~~~~
  
 -The merge and interactive backends work fine with
 -directory rename detection.  The am backend sometimes does not.
 +Directory rename heuristics are enabled in the merge and interactive
 +backends.  Due to the lack of accurate tree information, directory
 +rename detection is disabled in the am backend.
  
  include::merge-strategies.txt[]
  
@@@ -980,7 -990,7 +991,7 @@@ when the merge operation did not even s
  
  At this time, the `merge` command will *always* use the `recursive`
  merge strategy for regular merges, and `octopus` for octopus merges,
 -strategy, with no way to choose a different one. To work around
 +with no way to choose a different one. To work around
  this, an `exec` command can be used to call `git merge` explicitly,
  using the fact that the labels are worktree-local refs (the ref
  `refs/rewritten/onto` would correspond to the label `onto`, for example).
diff --combined builtin/rebase--interactive.c
index dd2a55ab1d,a9ab009fdb..c2c2d51a3b
--- a/builtin/rebase--interactive.c
+++ b/builtin/rebase--interactive.c
@@@ -105,7 -105,7 +105,7 @@@ static int do_interactive_rebase(struc
  	if (restrict_revision)
  		argv_array_push(&make_script_args, restrict_revision);
  
 -	ret = sequencer_make_script(todo_list,
 +	ret = sequencer_make_script(the_repository, todo_list,
  				    make_script_args.argc, make_script_args.argv,
  				    flags);
  	fclose(todo_list);
@@@ -114,8 -114,7 +114,8 @@@
  		error(_("could not generate todo list"));
  	else {
  		discard_cache();
 -		ret = complete_action(opts, flags, shortrevisions, onto_name, onto,
 +		ret = complete_action(the_repository, opts, flags,
 +				      shortrevisions, onto_name, onto,
  				      head_hash, cmd, autosquash);
  	}
  
@@@ -193,6 -192,8 +193,8 @@@ int cmd_rebase__interactive(int argc, c
  		OPT_STRING(0, "onto-name", &onto_name, N_("onto-name"), N_("onto name")),
  		OPT_STRING(0, "cmd", &cmd, N_("cmd"), N_("the command to run")),
  		OPT_RERERE_AUTOUPDATE(&opts.allow_rerere_auto),
+ 		OPT_BOOL(0, "reschedule-failed-exec", &opts.reschedule_failed_exec,
+ 			 N_("automatically re-schedule any `exec` that fails")),
  		OPT_END()
  	};
  
@@@ -233,14 -234,14 +235,14 @@@
  	case SKIP: {
  		struct string_list merge_rr = STRING_LIST_INIT_DUP;
  
 -		rerere_clear(&merge_rr);
 +		rerere_clear(the_repository, &merge_rr);
  		/* fallthrough */
  	case CONTINUE:
 -		ret = sequencer_continue(&opts);
 +		ret = sequencer_continue(the_repository, &opts);
  		break;
  	}
  	case EDIT_TODO:
 -		ret = edit_todo_list(flags);
 +		ret = edit_todo_list(the_repository, flags);
  		break;
  	case SHOW_CURRENT_PATCH: {
  		struct child_process cmd = CHILD_PROCESS_INIT;
@@@ -253,16 -254,16 +255,16 @@@
  	}
  	case SHORTEN_OIDS:
  	case EXPAND_OIDS:
 -		ret = transform_todos(flags);
 +		ret = transform_todos(the_repository, flags);
  		break;
  	case CHECK_TODO_LIST:
 -		ret = check_todo_list();
 +		ret = check_todo_list(the_repository);
  		break;
  	case REARRANGE_SQUASH:
 -		ret = rearrange_squash();
 +		ret = rearrange_squash(the_repository);
  		break;
  	case ADD_EXEC:
 -		ret = sequencer_add_exec_commands(cmd);
 +		ret = sequencer_add_exec_commands(the_repository, cmd);
  		break;
  	default:
  		BUG("invalid command '%d'", command);
diff --combined builtin/rebase.c
index 00de70365e,1963076f60..26a6d0ea33
--- a/builtin/rebase.c
+++ b/builtin/rebase.c
@@@ -104,6 -104,7 +104,7 @@@ struct rebase_options 
  	int rebase_merges, rebase_cousins;
  	char *strategy, *strategy_opts;
  	struct strbuf git_format_patch_opt;
+ 	int reschedule_failed_exec;
  };
  
  static int is_interactive(struct rebase_options *opts)
@@@ -415,6 -416,8 +416,8 @@@ static int run_specific_rebase(struct r
  			argv_array_push(&child.args, opts->gpg_sign_opt);
  		if (opts->signoff)
  			argv_array_push(&child.args, "--signoff");
+ 		if (opts->reschedule_failed_exec)
+ 			argv_array_push(&child.args, "--reschedule-failed-exec");
  
  		status = run_command(&child);
  		goto finished_rebase;
@@@ -598,7 -601,7 +601,7 @@@ static int reset_head(struct object_id 
  	}
  
  	tree = parse_tree_indirect(oid);
 -	prime_cache_tree(the_repository->index, tree);
 +	prime_cache_tree(the_repository, the_repository->index, tree);
  
  	if (write_locked_index(the_repository->index, &lock, COMMIT_LOCK) < 0) {
  		ret = error(_("could not write index"));
@@@ -674,6 -677,11 +677,11 @@@ static int rebase_config(const char *va
  		return 0;
  	}
  
+ 	if (!strcmp(var, "rebase.reschedulefailedexec")) {
+ 		opts->reschedule_failed_exec = git_config_bool(var, value);
+ 		return 0;
+ 	}
+ 
  	return git_default_config(var, value, data);
  }
  
@@@ -746,6 -754,23 +754,23 @@@ static int parse_opt_interactive(const 
  	return 0;
  }
  
+ struct opt_y {
+ 	struct string_list *list;
+ 	struct rebase_options *options;
+ };
+ 
+ static int parse_opt_y(const struct option *opt, const char *arg, int unset)
+ {
+ 	struct opt_y *o = opt->value;
+ 
+ 	if (unset || !arg)
+ 		return -1;
+ 
+ 	o->options->reschedule_failed_exec = 1;
+ 	string_list_append(o->list, arg);
+ 	return 0;
+ }
+ 
  static void NORETURN error_on_missing_default_upstream(void)
  {
  	struct branch *current_branch = branch_get(NULL);
@@@ -826,6 -851,7 +851,7 @@@ int cmd_rebase(int argc, const char **a
  	struct string_list strategy_options = STRING_LIST_INIT_NODUP;
  	struct object_id squash_onto;
  	char *squash_onto_name = NULL;
+ 	struct opt_y opt_y = { .list = &exec, .options = &options };
  	struct option builtin_rebase_options[] = {
  		OPT_STRING(0, "onto", &options.onto_name,
  			   N_("revision"),
@@@ -903,6 -929,9 +929,9 @@@
  		OPT_STRING_LIST('x', "exec", &exec, N_("exec"),
  				N_("add exec lines after each commit of the "
  				   "editable list")),
+ 		{ OPTION_CALLBACK, 'y', NULL, &opt_y, N_("<cmd>"),
+ 			N_("same as --reschedule-failed-exec -x <cmd>"),
+ 			PARSE_OPT_NONEG, parse_opt_y },
  		OPT_BOOL(0, "allow-empty-message",
  			 &options.allow_empty_message,
  			 N_("allow rebasing commits with empty messages")),
@@@ -920,6 -949,9 +949,9 @@@
  				   "strategy")),
  		OPT_BOOL(0, "root", &options.root,
  			 N_("rebase all reachable commits up to the root(s)")),
+ 		OPT_BOOL(0, "reschedule-failed-exec",
+ 			 &options.reschedule_failed_exec,
+ 			 N_("automatically re-schedule any `exec` that fails")),
  		OPT_END(),
  	};
  	int i;
@@@ -1024,7 -1056,7 +1056,7 @@@
  					     &lock_file);
  		rollback_lock_file(&lock_file);
  
 -		if (has_unstaged_changes(1)) {
 +		if (has_unstaged_changes(the_repository, 1)) {
  			puts(_("You must edit all merge conflicts and then\n"
  			       "mark them as resolved using git add"));
  			exit(1);
@@@ -1039,13 -1071,13 +1071,13 @@@
  		options.action = "skip";
  		set_reflog_action(&options);
  
 -		rerere_clear(&merge_rr);
 +		rerere_clear(the_repository, &merge_rr);
  		string_list_clear(&merge_rr, 1);
  
  		if (reset_head(NULL, "reset", NULL, RESET_HEAD_HARD,
  			       NULL, NULL) < 0)
  			die(_("could not discard worktree changes"));
 -		remove_branch_state();
 +		remove_branch_state(the_repository);
  		if (read_basic_state(&options))
  			exit(1);
  		goto run_rebase;
@@@ -1055,7 -1087,7 +1087,7 @@@
  		options.action = "abort";
  		set_reflog_action(&options);
  
 -		rerere_clear(&merge_rr);
 +		rerere_clear(the_repository, &merge_rr);
  		string_list_clear(&merge_rr, 1);
  
  		if (read_basic_state(&options))
@@@ -1065,7 -1097,7 +1097,7 @@@
  			       NULL, NULL) < 0)
  			die(_("could not move back to %s"),
  			    oid_to_hex(&options.orig_head));
 -		remove_branch_state();
 +		remove_branch_state(the_repository);
  		ret = finish_rebase(&options);
  		goto cleanup;
  	}
@@@ -1216,6 -1248,9 +1248,9 @@@
  		break;
  	}
  
+ 	if (options.reschedule_failed_exec && !is_interactive(&options))
+ 		die(_("--reschedule-failed-exec requires an interactive rebase"));
+ 
  	if (options.git_am_opts.argc) {
  		/* all am options except -q are compatible only with --am */
  		for (i = options.git_am_opts.argc - 1; i >= 0; i--)
@@@ -1241,7 -1276,7 +1276,7 @@@
  		options.flags |= REBASE_FORCE;
  	}
  
- 	if (options.type == REBASE_PRESERVE_MERGES)
+ 	if (options.type == REBASE_PRESERVE_MERGES) {
  		/*
  		 * Note: incompatibility with --signoff handled in signoff block above
  		 * Note: incompatibility with --interactive is just a strong warning;
@@@ -1251,6 -1286,11 +1286,11 @@@
  			die(_("error: cannot combine '--preserve-merges' with "
  			      "'--rebase-merges'"));
  
+ 		if (options.reschedule_failed_exec)
+ 			die(_("error: cannot combine '--preserve-merges' with "
+ 			      "'--reschedule-failed-exec'"));
+ 	}
+ 
  	if (options.rebase_merges) {
  		if (strategy_options.nr)
  			die(_("error: cannot combine '--rebase-merges' with "
@@@ -1381,8 -1421,7 +1421,8 @@@
  			update_index_if_able(&the_index, &lock_file);
  		rollback_lock_file(&lock_file);
  
 -		if (has_unstaged_changes(1) || has_uncommitted_changes(1)) {
 +		if (has_unstaged_changes(the_repository, 1) ||
 +		    has_uncommitted_changes(the_repository, 1)) {
  			const char *autostash =
  				state_dir_path("autostash", &options);
  			struct child_process stash = CHILD_PROCESS_INIT;
@@@ -1428,7 -1467,7 +1468,7 @@@
  		}
  	}
  
 -	if (require_clean_work_tree("rebase",
 +	if (require_clean_work_tree(the_repository, "rebase",
  				    _("Please commit or stash them."), 1, 1)) {
  		ret = 1;
  		goto cleanup;
diff --combined sequencer.c
index f5370f4965,69bee63e11..213815dbfc
--- a/sequencer.c
+++ b/sequencer.c
@@@ -158,6 -158,7 +158,7 @@@ static GIT_PATH_FUNC(rebase_path_strate
  static GIT_PATH_FUNC(rebase_path_strategy_opts, "rebase-merge/strategy_opts")
  static GIT_PATH_FUNC(rebase_path_allow_rerere_autoupdate, "rebase-merge/allow_rerere_autoupdate")
  static GIT_PATH_FUNC(rebase_path_quiet, "rebase-merge/quiet")
+ static GIT_PATH_FUNC(rebase_path_reschedule_failed_exec, "rebase-merge/reschedule-failed-exec")
  
  static int git_sequencer_config(const char *k, const char *v, void *cb)
  {
@@@ -356,8 -357,7 +357,8 @@@ static void free_message(struct commit 
  	unuse_commit_buffer(commit, msg->message);
  }
  
 -static void print_advice(int show_hint, struct replay_opts *opts)
 +static void print_advice(struct repository *r, int show_hint,
 +			 struct replay_opts *opts)
  {
  	char *msg = getenv("GIT_CHERRY_PICK_HELP");
  
@@@ -368,7 -368,7 +369,7 @@@
  		 * (typically rebase --interactive) wants to take care
  		 * of the commit itself so remove CHERRY_PICK_HEAD
  		 */
 -		unlink(git_path_cherry_pick_head(the_repository));
 +		unlink(git_path_cherry_pick_head(r));
  		return;
  	}
  
@@@ -441,14 -441,14 +442,14 @@@ static int read_oneliner(struct strbuf 
  	return 1;
  }
  
 -static struct tree *empty_tree(void)
 +static struct tree *empty_tree(struct repository *r)
  {
 -	return lookup_tree(the_repository, the_repository->hash_algo->empty_tree);
 +	return lookup_tree(r, the_hash_algo->empty_tree);
  }
  
 -static int error_dirty_index(struct replay_opts *opts)
 +static int error_dirty_index(struct index_state *istate, struct replay_opts *opts)
  {
 -	if (read_cache_unmerged())
 +	if (read_index_unmerged(istate))
  		return error_resolve_conflict(_(action_name(opts)));
  
  	error(_("your local changes would be overwritten by %s."),
@@@ -473,18 -473,15 +474,18 @@@ static void update_abort_safety_file(vo
  		write_file(git_path_abort_safety_file(), "%s", "");
  }
  
 -static int fast_forward_to(const struct object_id *to, const struct object_id *from,
 -			int unborn, struct replay_opts *opts)
 +static int fast_forward_to(struct repository *r,
 +			   const struct object_id *to,
 +			   const struct object_id *from,
 +			   int unborn,
 +			   struct replay_opts *opts)
  {
  	struct ref_transaction *transaction;
  	struct strbuf sb = STRBUF_INIT;
  	struct strbuf err = STRBUF_INIT;
  
 -	read_index(&the_index);
 -	if (checkout_fast_forward(the_repository, from, to, 1))
 +	read_index(r->index);
 +	if (checkout_fast_forward(r, from, to, 1))
  		return -1; /* the callee should have complained already */
  
  	strbuf_addf(&sb, _("%s: fast-forward"), _(action_name(opts)));
@@@ -510,26 -507,24 +511,26 @@@
  	return 0;
  }
  
 -void append_conflicts_hint(struct strbuf *msgbuf)
 +void append_conflicts_hint(struct index_state *istate,
 +			   struct strbuf *msgbuf)
  {
  	int i;
  
  	strbuf_addch(msgbuf, '\n');
  	strbuf_commented_addf(msgbuf, "Conflicts:\n");
 -	for (i = 0; i < active_nr;) {
 -		const struct cache_entry *ce = active_cache[i++];
 +	for (i = 0; i < istate->cache_nr;) {
 +		const struct cache_entry *ce = istate->cache[i++];
  		if (ce_stage(ce)) {
  			strbuf_commented_addf(msgbuf, "\t%s\n", ce->name);
 -			while (i < active_nr && !strcmp(ce->name,
 -							active_cache[i]->name))
 +			while (i < istate->cache_nr &&
 +			       !strcmp(ce->name, istate->cache[i]->name))
  				i++;
  		}
  	}
  }
  
 -static int do_recursive_merge(struct commit *base, struct commit *next,
 +static int do_recursive_merge(struct repository *r,
 +			      struct commit *base, struct commit *next,
  			      const char *base_label, const char *next_label,
  			      struct object_id *head, struct strbuf *msgbuf,
  			      struct replay_opts *opts)
@@@ -543,7 -538,7 +544,7 @@@
  	if (hold_locked_index(&index_lock, LOCK_REPORT_ON_ERROR) < 0)
  		return -1;
  
 -	read_cache();
 +	read_index(r->index);
  
  	init_merge_options(&o);
  	o.ancestor = base ? base_label : "(empty tree)";
@@@ -554,8 -549,8 +555,8 @@@
  	o.show_rename_progress = 1;
  
  	head_tree = parse_tree_indirect(head);
 -	next_tree = next ? get_commit_tree(next) : empty_tree();
 -	base_tree = base ? get_commit_tree(base) : empty_tree();
 +	next_tree = next ? get_commit_tree(next) : empty_tree(r);
 +	base_tree = base ? get_commit_tree(base) : empty_tree(r);
  
  	for (xopt = opts->xopts; xopt != opts->xopts + opts->xopts_nr; xopt++)
  		parse_merge_opt(&o, *xopt);
@@@ -572,7 -567,7 +573,7 @@@
  		return clean;
  	}
  
 -	if (write_locked_index(&the_index, &index_lock,
 +	if (write_locked_index(r->index, &index_lock,
  			       COMMIT_LOCK | SKIP_IF_UNCHANGED))
  		/*
  		 * TRANSLATORS: %s will be "revert", "cherry-pick" or
@@@ -582,35 -577,34 +583,35 @@@
  			_(action_name(opts)));
  
  	if (!clean)
 -		append_conflicts_hint(msgbuf);
 +		append_conflicts_hint(r->index, msgbuf);
  
  	return !clean;
  }
  
 -static struct object_id *get_cache_tree_oid(void)
 +static struct object_id *get_cache_tree_oid(struct index_state *istate)
  {
 -	if (!active_cache_tree)
 -		active_cache_tree = cache_tree();
 +	if (!istate->cache_tree)
 +		istate->cache_tree = cache_tree();
  
 -	if (!cache_tree_fully_valid(active_cache_tree))
 -		if (cache_tree_update(&the_index, 0)) {
 +	if (!cache_tree_fully_valid(istate->cache_tree))
 +		if (cache_tree_update(istate, 0)) {
  			error(_("unable to update cache tree"));
  			return NULL;
  		}
  
 -	return &active_cache_tree->oid;
 +	return &istate->cache_tree->oid;
  }
  
 -static int is_index_unchanged(void)
 +static int is_index_unchanged(struct repository *r)
  {
  	struct object_id head_oid, *cache_tree_oid;
  	struct commit *head_commit;
 +	struct index_state *istate = r->index;
  
  	if (!resolve_ref_unsafe("HEAD", RESOLVE_REF_READING, &head_oid, NULL))
  		return error(_("could not resolve HEAD commit"));
  
 -	head_commit = lookup_commit(the_repository, &head_oid);
 +	head_commit = lookup_commit(r, &head_oid);
  
  	/*
  	 * If head_commit is NULL, check_commit, called from
@@@ -623,7 -617,7 +624,7 @@@
  	if (parse_commit(head_commit))
  		return -1;
  
 -	if (!(cache_tree_oid = get_cache_tree_oid()))
 +	if (!(cache_tree_oid = get_cache_tree_oid(istate)))
  		return -1;
  
  	return oideq(cache_tree_oid, get_commit_tree_oid(head_commit));
@@@ -895,9 -889,7 +896,9 @@@ static int run_command_silent_on_succes
   * interactive rebase: in that case, we will want to retain the
   * author metadata.
   */
 -static int run_git_commit(const char *defmsg, struct replay_opts *opts,
 +static int run_git_commit(struct repository *r,
 +			  const char *defmsg,
 +			  struct replay_opts *opts,
  			  unsigned int flags)
  {
  	struct child_process cmd = CHILD_PROCESS_INIT;
@@@ -920,7 -912,7 +921,7 @@@
  		if (!defmsg)
  			BUG("root commit without message");
  
 -		if (!(cache_tree_oid = get_cache_tree_oid()))
 +		if (!(cache_tree_oid = get_cache_tree_oid(r->index)))
  			res = -1;
  
  		if (!res)
@@@ -1129,9 -1121,7 +1130,9 @@@ void commit_post_rewrite(const struct c
  	run_rewrite_hook(&old_head->object.oid, new_head);
  }
  
 -static int run_prepare_commit_msg_hook(struct strbuf *msg, const char *commit)
 +static int run_prepare_commit_msg_hook(struct repository *r,
 +				       struct strbuf *msg,
 +				       const char *commit)
  {
  	struct argv_array hook_env = ARGV_ARRAY_INIT;
  	int ret;
@@@ -1141,7 -1131,7 +1142,7 @@@
  	if (write_message(msg->buf, msg->len, name, 0))
  		return -1;
  
 -	argv_array_pushf(&hook_env, "GIT_INDEX_FILE=%s", get_index_file());
 +	argv_array_pushf(&hook_env, "GIT_INDEX_FILE=%s", r->index_file);
  	argv_array_push(&hook_env, "GIT_EDITOR=:");
  	if (commit)
  		ret = run_hook_le(hook_env.argv, "prepare-commit-msg", name,
@@@ -1197,9 -1187,7 +1198,9 @@@ static const char *implicit_ident_advic
  
  }
  
 -void print_commit_summary(const char *prefix, const struct object_id *oid,
 +void print_commit_summary(struct repository *r,
 +			  const char *prefix,
 +			  const struct object_id *oid,
  			  unsigned int flags)
  {
  	struct rev_info rev;
@@@ -1210,7 -1198,7 +1211,7 @@@
  	struct strbuf author_ident = STRBUF_INIT;
  	struct strbuf committer_ident = STRBUF_INIT;
  
 -	commit = lookup_commit(the_repository, oid);
 +	commit = lookup_commit(r, oid);
  	if (!commit)
  		die(_("couldn't look up newly created commit"));
  	if (parse_commit(commit))
@@@ -1243,7 -1231,7 +1244,7 @@@
  	strbuf_release(&author_ident);
  	strbuf_release(&committer_ident);
  
 -	repo_init_revisions(the_repository, &rev, prefix);
 +	repo_init_revisions(r, &rev, prefix);
  	setup_revisions(0, NULL, &rev, NULL);
  
  	rev.diff = 1;
@@@ -1277,7 -1265,7 +1278,7 @@@
  	strbuf_release(&format);
  }
  
 -static int parse_head(struct commit **head)
 +static int parse_head(struct repository *r, struct commit **head)
  {
  	struct commit *current_head;
  	struct object_id oid;
@@@ -1285,7 -1273,7 +1286,7 @@@
  	if (get_oid("HEAD", &oid)) {
  		current_head = NULL;
  	} else {
 -		current_head = lookup_commit_reference(the_repository, &oid);
 +		current_head = lookup_commit_reference(r, &oid);
  		if (!current_head)
  			return error(_("could not parse HEAD"));
  		if (!oideq(&oid, &current_head->object.oid)) {
@@@ -1309,8 -1297,7 +1310,8 @@@
   *   0 - success
   *   1 - run 'git commit'
   */
 -static int try_to_commit(struct strbuf *msg, const char *author,
 +static int try_to_commit(struct repository *r,
 +			 struct strbuf *msg, const char *author,
  			 struct replay_opts *opts, unsigned int flags,
  			 struct object_id *oid)
  {
@@@ -1325,7 -1312,7 +1326,7 @@@
  	enum commit_msg_cleanup_mode cleanup;
  	int res = 0;
  
 -	if (parse_head(&current_head))
 +	if (parse_head(r, &current_head))
  		return -1;
  
  	if (flags & AMEND_MSG) {
@@@ -1354,7 -1341,7 +1355,7 @@@
  		commit_list_insert(current_head, &parents);
  	}
  
 -	if (write_index_as_tree(&tree, &the_index, get_index_file(), 0, NULL)) {
 +	if (write_index_as_tree(&tree, r->index, r->index_file, 0, NULL)) {
  		res = error(_("git write-tree failed to write a tree"));
  		goto out;
  	}
@@@ -1367,7 -1354,7 +1368,7 @@@
  	}
  
  	if (find_hook("prepare-commit-msg")) {
 -		res = run_prepare_commit_msg_hook(msg, hook_commit);
 +		res = run_prepare_commit_msg_hook(r, msg, hook_commit);
  		if (res)
  			goto out;
  		if (strbuf_read_file(&commit_msg, git_path_commit_editmsg(),
@@@ -1416,8 -1403,7 +1417,8 @@@ out
  	return res;
  }
  
 -static int do_commit(const char *msg_file, const char *author,
 +static int do_commit(struct repository *r,
 +		     const char *msg_file, const char *author,
  		     struct replay_opts *opts, unsigned int flags)
  {
  	int res = 1;
@@@ -1432,20 -1418,20 +1433,20 @@@
  					     "from '%s'"),
  					   msg_file);
  
 -		res = try_to_commit(msg_file ? &sb : NULL, author, opts, flags,
 -				    &oid);
 +		res = try_to_commit(r, msg_file ? &sb : NULL,
 +				    author, opts, flags, &oid);
  		strbuf_release(&sb);
  		if (!res) {
 -			unlink(git_path_cherry_pick_head(the_repository));
 -			unlink(git_path_merge_msg(the_repository));
 +			unlink(git_path_cherry_pick_head(r));
 +			unlink(git_path_merge_msg(r));
  			if (!is_rebase_i(opts))
 -				print_commit_summary(NULL, &oid,
 +				print_commit_summary(r, NULL, &oid,
  						SUMMARY_SHOW_AUTHOR_DATE);
  			return res;
  		}
  	}
  	if (res == 1)
 -		return run_git_commit(msg_file, opts, flags);
 +		return run_git_commit(r, msg_file, opts, flags);
  
  	return res;
  }
@@@ -1473,9 -1459,7 +1474,9 @@@ static int is_original_commit_empty(str
  /*
   * Do we run "git commit" with "--allow-empty"?
   */
 -static int allow_empty(struct replay_opts *opts, struct commit *commit)
 +static int allow_empty(struct repository *r,
 +		       struct replay_opts *opts,
 +		       struct commit *commit)
  {
  	int index_unchanged, empty_commit;
  
@@@ -1492,7 -1476,7 +1493,7 @@@
  	if (!opts->allow_empty)
  		return 0; /* let "git commit" barf as necessary */
  
 -	index_unchanged = is_index_unchanged();
 +	index_unchanged = is_index_unchanged(r);
  	if (index_unchanged < 0)
  		return index_unchanged;
  	if (!index_unchanged)
@@@ -1596,10 -1580,8 +1597,10 @@@ static int is_pick_or_similar(enum todo
  	}
  }
  
 -static int update_squash_messages(enum todo_command command,
 -		struct commit *commit, struct replay_opts *opts)
 +static int update_squash_messages(struct repository *r,
 +				  enum todo_command command,
 +				  struct commit *commit,
 +				  struct replay_opts *opts)
  {
  	struct strbuf buf = STRBUF_INIT;
  	int res;
@@@ -1628,7 -1610,7 +1629,7 @@@
  
  		if (get_oid("HEAD", &head))
  			return error(_("need a HEAD to fixup"));
 -		if (!(head_commit = lookup_commit_reference(the_repository, &head)))
 +		if (!(head_commit = lookup_commit_reference(r, &head)))
  			return error(_("could not read HEAD"));
  		if (!(head_message = get_commit_buffer(head_commit, NULL)))
  			return error(_("could not read HEAD's commit message"));
@@@ -1689,8 -1671,7 +1690,8 @@@
  	return res;
  }
  
 -static void flush_rewritten_pending(void) {
 +static void flush_rewritten_pending(void)
 +{
  	struct strbuf buf = STRBUF_INIT;
  	struct object_id newoid;
  	FILE *out;
@@@ -1715,8 -1696,7 +1716,8 @@@
  }
  
  static void record_in_rewritten(struct object_id *oid,
 -		enum todo_command next_command) {
 +		enum todo_command next_command)
 +{
  	FILE *out = fopen_or_warn(rebase_path_rewritten_pending(), "a");
  
  	if (!out)
@@@ -1729,14 -1709,11 +1730,14 @@@
  		flush_rewritten_pending();
  }
  
 -static int do_pick_commit(enum todo_command command, struct commit *commit,
 -		struct replay_opts *opts, int final_fixup)
 +static int do_pick_commit(struct repository *r,
 +			  enum todo_command command,
 +			  struct commit *commit,
 +			  struct replay_opts *opts,
 +			  int final_fixup)
  {
  	unsigned int flags = opts->edit ? EDIT_MSG : 0;
 -	const char *msg_file = opts->edit ? NULL : git_path_merge_msg(the_repository);
 +	const char *msg_file = opts->edit ? NULL : git_path_merge_msg(r);
  	struct object_id head;
  	struct commit *base, *next, *parent;
  	const char *base_label, *next_label;
@@@ -1752,7 -1729,7 +1753,7 @@@
  		 * that represents the "current" state for merge-recursive
  		 * to work on.
  		 */
 -		if (write_index_as_tree(&head, &the_index, get_index_file(), 0, NULL))
 +		if (write_index_as_tree(&head, r->index, r->index_file, 0, NULL))
  			return error(_("your index file is unmerged."));
  	} else {
  		unborn = get_oid("HEAD", &head);
@@@ -1765,11 -1742,11 +1766,11 @@@
  			unborn = 1;
  		} else if (unborn)
  			oidcpy(&head, the_hash_algo->empty_tree);
 -		if (index_differs_from(unborn ? empty_tree_oid_hex() : "HEAD",
 +		if (index_differs_from(r, unborn ? empty_tree_oid_hex() : "HEAD",
  				       NULL, 0))
 -			return error_dirty_index(opts);
 +			return error_dirty_index(r->index, opts);
  	}
 -	discard_cache();
 +	discard_index(r->index);
  
  	if (!commit->parents)
  		parent = NULL;
@@@ -1790,13 -1767,9 +1791,13 @@@
  			return error(_("commit %s does not have parent %d"),
  				oid_to_hex(&commit->object.oid), opts->mainline);
  		parent = p->item;
 -	} else if (0 < opts->mainline)
 -		return error(_("mainline was specified but commit %s is not a merge."),
 -			oid_to_hex(&commit->object.oid));
 +	} else if (1 < opts->mainline)
 +		/*
 +		 *  Non-first parent explicitly specified as mainline for
 +		 *  non-merge commit
 +		 */
 +		return error(_("commit %s does not have parent %d"),
 +			     oid_to_hex(&commit->object.oid), opts->mainline);
  	else
  		parent = commit->parents->item;
  
@@@ -1809,7 -1782,7 +1810,7 @@@
  	     (!parent && unborn))) {
  		if (is_rebase_i(opts))
  			write_author_script(msg.message);
 -		res = fast_forward_to(&commit->object.oid, &head, unborn,
 +		res = fast_forward_to(r, &commit->object.oid, &head, unborn,
  			opts);
  		if (res || command != TODO_REWORD)
  			goto leave;
@@@ -1873,7 -1846,7 +1874,7 @@@
  	if (command == TODO_REWORD)
  		flags |= EDIT_MSG | VERIFY_MSG;
  	else if (is_fixup(command)) {
 -		if (update_squash_messages(command, commit, opts))
 +		if (update_squash_messages(r, command, commit, opts))
  			return -1;
  		flags |= AMEND_MSG;
  		if (!final_fixup)
@@@ -1882,12 -1855,12 +1883,12 @@@
  			flags |= CLEANUP_MSG;
  			msg_file = rebase_path_fixup_msg();
  		} else {
 -			const char *dest = git_path_squash_msg(the_repository);
 +			const char *dest = git_path_squash_msg(r);
  			unlink(dest);
  			if (copy_file(dest, rebase_path_squash_msg(), 0666))
  				return error(_("could not rename '%s' to '%s'"),
  					     rebase_path_squash_msg(), dest);
 -			unlink(git_path_merge_msg(the_repository));
 +			unlink(git_path_merge_msg(r));
  			msg_file = dest;
  			flags |= EDIT_MSG;
  		}
@@@ -1899,23 -1872,23 +1900,23 @@@
  	if (is_rebase_i(opts) && write_author_script(msg.message) < 0)
  		res = -1;
  	else if (!opts->strategy || !strcmp(opts->strategy, "recursive") || command == TODO_REVERT) {
 -		res = do_recursive_merge(base, next, base_label, next_label,
 +		res = do_recursive_merge(r, base, next, base_label, next_label,
  					 &head, &msgbuf, opts);
  		if (res < 0)
  			goto leave;
  
  		res |= write_message(msgbuf.buf, msgbuf.len,
 -				     git_path_merge_msg(the_repository), 0);
 +				     git_path_merge_msg(r), 0);
  	} else {
  		struct commit_list *common = NULL;
  		struct commit_list *remotes = NULL;
  
  		res = write_message(msgbuf.buf, msgbuf.len,
 -				    git_path_merge_msg(the_repository), 0);
 +				    git_path_merge_msg(r), 0);
  
  		commit_list_insert(base, &common);
  		commit_list_insert(next, &remotes);
 -		res |= try_merge_command(the_repository, opts->strategy,
 +		res |= try_merge_command(r, opts->strategy,
  					 opts->xopts_nr, (const char **)opts->xopts,
  					common, oid_to_hex(&head), remotes);
  		free_commit_list(common);
@@@ -1943,12 -1916,12 +1944,12 @@@
  		      ? _("could not revert %s... %s")
  		      : _("could not apply %s... %s"),
  		      short_commit_name(commit), msg.subject);
 -		print_advice(res == 1, opts);
 -		repo_rerere(the_repository, opts->allow_rerere_auto);
 +		print_advice(r, res == 1, opts);
 +		repo_rerere(r, opts->allow_rerere_auto);
  		goto leave;
  	}
  
 -	allow = allow_empty(opts, commit);
 +	allow = allow_empty(r, opts, commit);
  	if (allow < 0) {
  		res = allow;
  		goto leave;
@@@ -1957,7 -1930,7 +1958,7 @@@
  	if (!opts->no_commit) {
  fast_forward_edit:
  		if (author || command == TODO_REVERT || (flags & AMEND_MSG))
 -			res = do_commit(msg_file, author, opts, flags);
 +			res = do_commit(r, msg_file, author, opts, flags);
  		else
  			res = error(_("unable to parse commit author"));
  	}
@@@ -1993,19 -1966,18 +1994,19 @@@ static int prepare_revs(struct replay_o
  	return 0;
  }
  
 -static int read_and_refresh_cache(struct replay_opts *opts)
 +static int read_and_refresh_cache(struct repository *r,
 +				  struct replay_opts *opts)
  {
  	struct lock_file index_lock = LOCK_INIT;
  	int index_fd = hold_locked_index(&index_lock, 0);
 -	if (read_index(&the_index) < 0) {
 +	if (read_index(r->index) < 0) {
  		rollback_lock_file(&index_lock);
  		return error(_("git %s: failed to read the index"),
  			_(action_name(opts)));
  	}
 -	refresh_index(&the_index, REFRESH_QUIET|REFRESH_UNMERGED, NULL, NULL, NULL);
 +	refresh_index(r->index, REFRESH_QUIET|REFRESH_UNMERGED, NULL, NULL, NULL);
  	if (index_fd >= 0) {
 -		if (write_locked_index(&the_index, &index_lock,
 +		if (write_locked_index(r->index, &index_lock,
  				       COMMIT_LOCK | SKIP_IF_UNCHANGED)) {
  			return error(_("git %s: failed to refresh the index"),
  				_(action_name(opts)));
@@@ -2050,8 -2022,7 +2051,8 @@@ static struct todo_item *append_new_tod
  	return todo_list->items + todo_list->nr++;
  }
  
 -static int parse_insn_line(struct todo_item *item, const char *bol, char *eol)
 +static int parse_insn_line(struct repository *r, struct todo_item *item,
 +			   const char *bol, char *eol)
  {
  	struct object_id commit_oid;
  	char *end_of_object_name;
@@@ -2136,12 -2107,11 +2137,12 @@@
  	if (status < 0)
  		return -1;
  
 -	item->commit = lookup_commit_reference(the_repository, &commit_oid);
 +	item->commit = lookup_commit_reference(r, &commit_oid);
  	return !item->commit;
  }
  
 -static int parse_insn_buffer(char *buf, struct todo_list *todo_list)
 +static int parse_insn_buffer(struct repository *r, char *buf,
 +			     struct todo_list *todo_list)
  {
  	struct todo_item *item;
  	char *p = buf, *next_p;
@@@ -2157,7 -2127,7 +2158,7 @@@
  
  		item = append_new_todo(todo_list);
  		item->offset_in_buf = p - todo_list->buf.buf;
 -		if (parse_insn_line(item, p, eol)) {
 +		if (parse_insn_line(r, item, p, eol)) {
  			res = error(_("invalid line %d: %.*s"),
  				i, (int)(eol - p), p);
  			item->command = TODO_NOOP;
@@@ -2218,9 -2188,8 +2219,9 @@@ static ssize_t strbuf_read_file_or_whin
  	return len;
  }
  
 -static int read_populate_todo(struct todo_list *todo_list,
 -			struct replay_opts *opts)
 +static int read_populate_todo(struct repository *r,
 +			      struct todo_list *todo_list,
 +			      struct replay_opts *opts)
  {
  	struct stat st;
  	const char *todo_file = get_todo_path(opts);
@@@ -2235,7 -2204,7 +2236,7 @@@
  		return error(_("could not stat '%s'"), todo_file);
  	fill_stat_data(&todo_list->stat, &st);
  
 -	res = parse_insn_buffer(todo_list->buf.buf, todo_list);
 +	res = parse_insn_buffer(r, todo_list->buf.buf, todo_list);
  	if (res) {
  		if (is_rebase_i(opts))
  			return error(_("please fix this using "
@@@ -2266,7 -2235,7 +2267,7 @@@
  		FILE *f = fopen_or_warn(rebase_path_msgtotal(), "w");
  
  		if (strbuf_read_file(&done.buf, rebase_path_done(), 0) > 0 &&
 -				!parse_insn_buffer(done.buf.buf, &done))
 +		    !parse_insn_buffer(r, done.buf.buf, &done))
  			todo_list->done_nr = count_commands(&done);
  		else
  			todo_list->done_nr = 0;
@@@ -2394,6 -2363,9 +2395,9 @@@ static int read_populate_opts(struct re
  			opts->signoff = 1;
  		}
  
+ 		if (file_exists(rebase_path_reschedule_failed_exec()))
+ 			opts->reschedule_failed_exec = 1;
+ 
  		read_strategy_opts(opts, &buf);
  		strbuf_release(&buf);
  
@@@ -2475,6 -2447,8 +2479,8 @@@ int write_basic_state(struct replay_opt
  		write_file(rebase_path_gpg_sign_opt(), "-S%s\n", opts->gpg_sign);
  	if (opts->signoff)
  		write_file(rebase_path_signoff(), "--signoff\n");
+ 	if (opts->reschedule_failed_exec)
+ 		write_file(rebase_path_reschedule_failed_exec(), "%s", "");
  
  	return 0;
  }
@@@ -2583,12 -2557,12 +2589,12 @@@ static int reset_for_rollback(const str
  	return run_command_v_opt(argv, RUN_GIT_CMD);
  }
  
 -static int rollback_single_pick(void)
 +static int rollback_single_pick(struct repository *r)
  {
  	struct object_id head_oid;
  
 -	if (!file_exists(git_path_cherry_pick_head(the_repository)) &&
 -	    !file_exists(git_path_revert_head(the_repository)))
 +	if (!file_exists(git_path_cherry_pick_head(r)) &&
 +	    !file_exists(git_path_revert_head(r)))
  		return error(_("no cherry-pick or revert in progress"));
  	if (read_ref_full("HEAD", 0, &head_oid, NULL))
  		return error(_("cannot resolve HEAD"));
@@@ -2597,7 -2571,7 +2603,7 @@@
  	return reset_for_rollback(&head_oid);
  }
  
 -int sequencer_rollback(struct replay_opts *opts)
 +int sequencer_rollback(struct repository *r, struct replay_opts *opts)
  {
  	FILE *f;
  	struct object_id oid;
@@@ -2611,7 -2585,7 +2617,7 @@@
  		 * If CHERRY_PICK_HEAD or REVERT_HEAD indicates
  		 * a single-cherry-pick in progress, abort that.
  		 */
 -		return rollback_single_pick();
 +		return rollback_single_pick(r);
  	}
  	if (!f)
  		return error_errno(_("cannot open '%s'"), git_path_head_file());
@@@ -2726,9 -2700,7 +2732,9 @@@ static int save_opts(struct replay_opt
  	return res;
  }
  
 -static int make_patch(struct commit *commit, struct replay_opts *opts)
 +static int make_patch(struct repository *r,
 +		      struct commit *commit,
 +		      struct replay_opts *opts)
  {
  	struct strbuf buf = STRBUF_INIT;
  	struct rev_info log_tree_opt;
@@@ -2744,7 -2716,7 +2750,7 @@@
  
  	strbuf_addf(&buf, "%s/patch", get_dir(opts));
  	memset(&log_tree_opt, 0, sizeof(log_tree_opt));
 -	repo_init_revisions(the_repository, &log_tree_opt, NULL);
 +	repo_init_revisions(r, &log_tree_opt, NULL);
  	log_tree_opt.abbrev = 0;
  	log_tree_opt.diff = 1;
  	log_tree_opt.diffopt.output_format = DIFF_FORMAT_PATCH;
@@@ -2784,19 -2756,17 +2790,19 @@@ static int intend_to_amend(void
  	return write_message(p, strlen(p), rebase_path_amend(), 1);
  }
  
 -static int error_with_patch(struct commit *commit,
 -	const char *subject, int subject_len,
 -	struct replay_opts *opts, int exit_code, int to_amend)
 +static int error_with_patch(struct repository *r,
 +			    struct commit *commit,
 +			    const char *subject, int subject_len,
 +			    struct replay_opts *opts,
 +			    int exit_code, int to_amend)
  {
  	if (commit) {
 -		if (make_patch(commit, opts))
 +		if (make_patch(r, commit, opts))
  			return -1;
  	} else if (copy_file(rebase_path_message(),
 -			     git_path_merge_msg(the_repository), 0666))
 +			     git_path_merge_msg(r), 0666))
  		return error(_("unable to copy '%s' to '%s'"),
 -			     git_path_merge_msg(the_repository), rebase_path_message());
 +			     git_path_merge_msg(r), rebase_path_message());
  
  	if (to_amend) {
  		if (intend_to_amend())
@@@ -2827,24 -2797,21 +2833,24 @@@
  	return exit_code;
  }
  
 -static int error_failed_squash(struct commit *commit,
 -	struct replay_opts *opts, int subject_len, const char *subject)
 +static int error_failed_squash(struct repository *r,
 +			       struct commit *commit,
 +			       struct replay_opts *opts,
 +			       int subject_len,
 +			       const char *subject)
  {
  	if (copy_file(rebase_path_message(), rebase_path_squash_msg(), 0666))
  		return error(_("could not copy '%s' to '%s'"),
  			rebase_path_squash_msg(), rebase_path_message());
 -	unlink(git_path_merge_msg(the_repository));
 -	if (copy_file(git_path_merge_msg(the_repository), rebase_path_message(), 0666))
 +	unlink(git_path_merge_msg(r));
 +	if (copy_file(git_path_merge_msg(r), rebase_path_message(), 0666))
  		return error(_("could not copy '%s' to '%s'"),
  			     rebase_path_message(),
 -			     git_path_merge_msg(the_repository));
 -	return error_with_patch(commit, subject, subject_len, opts, 1, 0);
 +			     git_path_merge_msg(r));
 +	return error_with_patch(r, commit, subject, subject_len, opts, 1, 0);
  }
  
 -static int do_exec(const char *command_line)
 +static int do_exec(struct repository *r, const char *command_line)
  {
  	struct argv_array child_env = ARGV_ARRAY_INIT;
  	const char *child_argv[] = { NULL, NULL };
@@@ -2859,10 -2826,10 +2865,10 @@@
  					  child_env.argv);
  
  	/* force re-reading of the cache */
 -	if (discard_cache() < 0 || read_cache() < 0)
 +	if (discard_index(r->index) < 0 || read_index(r->index) < 0)
  		return error(_("could not read index"));
  
 -	dirty = require_clean_work_tree("rebase", NULL, 1, 1);
 +	dirty = require_clean_work_tree(r, "rebase", NULL, 1, 1);
  
  	if (status) {
  		warning(_("execution failed: %s\n%s"
@@@ -2928,9 -2895,9 +2934,9 @@@ static int safe_append(const char *file
  	return 0;
  }
  
 -static int do_label(const char *name, int len)
 +static int do_label(struct repository *r, const char *name, int len)
  {
 -	struct ref_store *refs = get_main_ref_store(the_repository);
 +	struct ref_store *refs = get_main_ref_store(r);
  	struct ref_transaction *transaction;
  	struct strbuf ref_name = STRBUF_INIT, err = STRBUF_INIT;
  	struct strbuf msg = STRBUF_INIT;
@@@ -2971,9 -2938,7 +2977,9 @@@
  static const char *reflog_message(struct replay_opts *opts,
  	const char *sub_action, const char *fmt, ...);
  
 -static int do_reset(const char *name, int len, struct replay_opts *opts)
 +static int do_reset(struct repository *r,
 +		    const char *name, int len,
 +		    struct replay_opts *opts)
  {
  	struct strbuf ref_name = STRBUF_INIT;
  	struct object_id oid;
@@@ -3022,13 -2987,13 +3028,13 @@@
  	memset(&unpack_tree_opts, 0, sizeof(unpack_tree_opts));
  	setup_unpack_trees_porcelain(&unpack_tree_opts, "reset");
  	unpack_tree_opts.head_idx = 1;
 -	unpack_tree_opts.src_index = &the_index;
 -	unpack_tree_opts.dst_index = &the_index;
 +	unpack_tree_opts.src_index = r->index;
 +	unpack_tree_opts.dst_index = r->index;
  	unpack_tree_opts.fn = oneway_merge;
  	unpack_tree_opts.merge = 1;
  	unpack_tree_opts.update = 1;
  
 -	if (read_cache_unmerged()) {
 +	if (read_index_unmerged(r->index)) {
  		rollback_lock_file(&lock);
  		strbuf_release(&ref_name);
  		return error_resolve_conflict(_(action_name(opts)));
@@@ -3050,9 -3015,9 +3056,9 @@@
  	}
  
  	tree = parse_tree_indirect(&oid);
 -	prime_cache_tree(&the_index, tree);
 +	prime_cache_tree(r, r->index, tree);
  
 -	if (write_locked_index(&the_index, &lock, COMMIT_LOCK) < 0)
 +	if (write_locked_index(r->index, &lock, COMMIT_LOCK) < 0)
  		ret = error(_("could not write index"));
  	free((void *)desc.buffer);
  
@@@ -3085,9 -3050,7 +3091,9 @@@ static struct commit *lookup_label(cons
  	return commit;
  }
  
 -static int do_merge(struct commit *commit, const char *arg, int arg_len,
 +static int do_merge(struct repository *r,
 +		    struct commit *commit,
 +		    const char *arg, int arg_len,
  		    int flags, struct replay_opts *opts)
  {
  	int run_commit_flags = (flags & TODO_EDIT_MERGE_MSG) ?
@@@ -3154,7 -3117,7 +3160,7 @@@
  			ret = error(_("octopus merge cannot be executed on "
  				      "top of a [new root]"));
  		else
 -			ret = fast_forward_to(&to_merge->item->object.oid,
 +			ret = fast_forward_to(r, &to_merge->item->object.oid,
  					      &head_commit->object.oid, 0,
  					      opts);
  		goto leave_merge;
@@@ -3173,11 -3136,11 +3179,11 @@@
  		write_author_script(message);
  		find_commit_subject(message, &body);
  		len = strlen(body);
 -		ret = write_message(body, len, git_path_merge_msg(the_repository), 0);
 +		ret = write_message(body, len, git_path_merge_msg(r), 0);
  		unuse_commit_buffer(commit, message);
  		if (ret) {
  			error_errno(_("could not write '%s'"),
 -				    git_path_merge_msg(the_repository));
 +				    git_path_merge_msg(r));
  			goto leave_merge;
  		}
  	} else {
@@@ -3199,11 -3162,11 +3205,11 @@@
  			len = buf.len;
  		}
  
 -		ret = write_message(p, len, git_path_merge_msg(the_repository), 0);
 +		ret = write_message(p, len, git_path_merge_msg(r), 0);
  		strbuf_release(&buf);
  		if (ret) {
  			error_errno(_("could not write '%s'"),
 -				    git_path_merge_msg(the_repository));
 +				    git_path_merge_msg(r));
  			goto leave_merge;
  		}
  	}
@@@ -3239,7 -3202,7 +3245,7 @@@
  
  	if (can_fast_forward) {
  		rollback_lock_file(&lock);
 -		ret = fast_forward_to(&commit->object.oid,
 +		ret = fast_forward_to(r, &commit->object.oid,
  				      &head_commit->object.oid, 0, opts);
  		goto leave_merge;
  	}
@@@ -3264,7 -3227,7 +3270,7 @@@
  		argv_array_push(&cmd.args, "--no-log");
  		argv_array_push(&cmd.args, "--no-stat");
  		argv_array_push(&cmd.args, "-F");
 -		argv_array_push(&cmd.args, git_path_merge_msg(the_repository));
 +		argv_array_push(&cmd.args, git_path_merge_msg(r));
  		if (opts->gpg_sign)
  			argv_array_push(&cmd.args, opts->gpg_sign);
  
@@@ -3274,15 -3237,14 +3280,15 @@@
  					oid_to_hex(&j->item->object.oid));
  
  		strbuf_release(&ref_name);
 -		unlink(git_path_cherry_pick_head(the_repository));
 +		unlink(git_path_cherry_pick_head(r));
  		rollback_lock_file(&lock);
  
  		rollback_lock_file(&lock);
  		ret = run_command(&cmd);
  
  		/* force re-reading of the cache */
 -		if (!ret && (discard_cache() < 0 || read_cache() < 0))
 +		if (!ret && (discard_index(r->index) < 0 ||
 +			     read_index(r->index) < 0))
  			ret = error(_("could not read index"));
  		goto leave_merge;
  	}
@@@ -3297,14 -3259,14 +3303,14 @@@
  	}
  
  	write_message(oid_to_hex(&merge_commit->object.oid), GIT_SHA1_HEXSZ,
 -		      git_path_merge_head(the_repository), 0);
 -	write_message("no-ff", 5, git_path_merge_mode(the_repository), 0);
 +		      git_path_merge_head(r), 0);
 +	write_message("no-ff", 5, git_path_merge_mode(r), 0);
  
  	for (j = bases; j; j = j->next)
  		commit_list_insert(j->item, &reversed);
  	free_commit_list(bases);
  
 -	read_cache();
 +	read_index(r->index);
  	init_merge_options(&o);
  	o.branch1 = "HEAD";
  	o.branch2 = ref_name.buf;
@@@ -3329,23 -3291,23 +3335,23 @@@
  	 */
  	ret = !ret;
  
 -	if (active_cache_changed &&
 -	    write_locked_index(&the_index, &lock, COMMIT_LOCK)) {
 +	if (r->index->cache_changed &&
 +	    write_locked_index(r->index, &lock, COMMIT_LOCK)) {
  		ret = error(_("merge: Unable to write new index file"));
  		goto leave_merge;
  	}
  
  	rollback_lock_file(&lock);
  	if (ret)
 -		repo_rerere(the_repository, opts->allow_rerere_auto);
 +		repo_rerere(r, opts->allow_rerere_auto);
  	else
  		/*
  		 * In case of problems, we now want to return a positive
  		 * value (a negative one would indicate that the `merge`
  		 * command needs to be rescheduled).
  		 */
 -		ret = !!run_git_commit(git_path_merge_msg(the_repository), opts,
 -				     run_commit_flags);
 +		ret = !!run_git_commit(r, git_path_merge_msg(r), opts,
 +				       run_commit_flags);
  
  leave_merge:
  	strbuf_release(&ref_name);
@@@ -3493,14 -3455,14 +3499,14 @@@ static int checkout_onto(struct replay_
  	return update_ref(NULL, "ORIG_HEAD", &oid, NULL, 0, UPDATE_REFS_MSG_ON_ERR);
  }
  
 -static int stopped_at_head(void)
 +static int stopped_at_head(struct repository *r)
  {
  	struct object_id head;
  	struct commit *commit;
  	struct commit_message message;
  
  	if (get_oid("HEAD", &head) ||
 -	    !(commit = lookup_commit(the_repository, &head)) ||
 +	    !(commit = lookup_commit(r, &head)) ||
  	    parse_commit(commit) || get_message(commit, &message))
  		fprintf(stderr, _("Stopped at HEAD\n"));
  	else {
@@@ -3522,9 -3484,7 +3528,9 @@@ N_("Could not execute the todo command\
  "    git rebase --edit-todo\n"
  "    git rebase --continue\n");
  
 -static int pick_commits(struct todo_list *todo_list, struct replay_opts *opts)
 +static int pick_commits(struct repository *r,
 +			struct todo_list *todo_list,
 +			struct replay_opts *opts)
  {
  	int res = 0, reschedule = 0;
  
@@@ -3532,7 -3492,7 +3538,7 @@@
  	if (opts->allow_ff)
  		assert(!(opts->signoff || opts->no_commit ||
  				opts->record_origin || opts->edit));
 -	if (read_and_refresh_cache(opts))
 +	if (read_and_refresh_cache(r, opts))
  		return -1;
  
  	while (todo_list->current < todo_list->nr) {
@@@ -3562,14 -3522,14 +3568,14 @@@
  			delete_ref(NULL, "REBASE_HEAD", NULL, REF_NO_DEREF);
  
  			if (item->command == TODO_BREAK)
 -				return stopped_at_head();
 +				return stopped_at_head(r);
  		}
  		if (item->command <= TODO_SQUASH) {
  			if (is_rebase_i(opts))
  				setenv("GIT_REFLOG_ACTION", reflog_message(opts,
  					command_to_string(item->command), NULL),
  					1);
 -			res = do_pick_commit(item->command, item->commit,
 +			res = do_pick_commit(r, item->command, item->commit,
  					opts, is_final_fixup(todo_list));
  			if (is_rebase_i(opts) && res < 0) {
  				/* Reschedule */
@@@ -3589,7 -3549,7 +3595,7 @@@
  						_("Stopped at %s...  %.*s\n"),
  						short_commit_name(commit),
  						item->arg_len, item->arg);
 -				return error_with_patch(commit,
 +				return error_with_patch(r, commit,
  					item->arg, item->arg_len, opts, res,
  					!res);
  			}
@@@ -3599,7 -3559,7 +3605,7 @@@
  			if (res && is_fixup(item->command)) {
  				if (res == 1)
  					intend_to_amend();
 -				return error_failed_squash(item->commit, opts,
 +				return error_failed_squash(r, item->commit, opts,
  					item->arg_len, item->arg);
  			} else if (res && is_rebase_i(opts) && item->commit) {
  				int to_amend = 0;
@@@ -3618,7 -3578,7 +3624,7 @@@
  				      oideq(&opts->squash_onto, &oid))))
  					to_amend = 1;
  
 -				return res | error_with_patch(item->commit,
 +				return res | error_with_patch(r, item->commit,
  						item->arg, item->arg_len, opts,
  						res, to_amend);
  			}
@@@ -3628,30 -3588,31 +3634,31 @@@
  			struct stat st;
  
  			*end_of_arg = '\0';
 -			res = do_exec(item->arg);
 +			res = do_exec(r, item->arg);
  			*end_of_arg = saved;
  
  			/* Reread the todo file if it has changed. */
- 			if (res)
- 				; /* fall through */
- 			else if (stat(get_todo_path(opts), &st))
+ 			if (res) {
+ 				if (opts->reschedule_failed_exec)
+ 					reschedule = 1;
+ 			} else if (stat(get_todo_path(opts), &st))
  				res = error_errno(_("could not stat '%s'"),
  						  get_todo_path(opts));
  			else if (match_stat_data(&todo_list->stat, &st)) {
  				todo_list_release(todo_list);
 -				if (read_populate_todo(todo_list, opts))
 +				if (read_populate_todo(r, todo_list, opts))
  					res = -1; /* message was printed */
  				/* `current` will be incremented below */
  				todo_list->current = -1;
  			}
  		} else if (item->command == TODO_LABEL) {
 -			if ((res = do_label(item->arg, item->arg_len)))
 +			if ((res = do_label(r, item->arg, item->arg_len)))
  				reschedule = 1;
  		} else if (item->command == TODO_RESET) {
 -			if ((res = do_reset(item->arg, item->arg_len, opts)))
 +			if ((res = do_reset(r, item->arg, item->arg_len, opts)))
  				reschedule = 1;
  		} else if (item->command == TODO_MERGE) {
 -			if ((res = do_merge(item->commit,
 +			if ((res = do_merge(r, item->commit,
  					    item->arg, item->arg_len,
  					    item->flags, opts)) < 0)
  				reschedule = 1;
@@@ -3660,7 -3621,7 +3667,7 @@@
  						    peek_command(todo_list, 1));
  			if (res > 0)
  				/* failed with merge conflicts */
 -				return error_with_patch(item->commit,
 +				return error_with_patch(r, item->commit,
  							item->arg,
  							item->arg_len, opts,
  							res, 0);
@@@ -3676,8 -3637,7 +3683,8 @@@
  			if (save_todo(todo_list, opts))
  				return -1;
  			if (item->commit)
 -				return error_with_patch(item->commit,
 +				return error_with_patch(r,
 +							item->commit,
  							item->arg,
  							item->arg_len, opts,
  							res, 0);
@@@ -3742,7 -3702,7 +3749,7 @@@ cleanup_head_ref
  			struct object_id orig, head;
  
  			memset(&log_tree_opt, 0, sizeof(log_tree_opt));
 -			repo_init_revisions(the_repository, &log_tree_opt, NULL);
 +			repo_init_revisions(r, &log_tree_opt, NULL);
  			log_tree_opt.diff = 1;
  			log_tree_opt.diffopt.output_format =
  				DIFF_FORMAT_DIFFSTAT;
@@@ -3799,27 -3759,26 +3806,27 @@@
  	return sequencer_remove_state(opts);
  }
  
 -static int continue_single_pick(void)
 +static int continue_single_pick(struct repository *r)
  {
  	const char *argv[] = { "commit", NULL };
  
 -	if (!file_exists(git_path_cherry_pick_head(the_repository)) &&
 -	    !file_exists(git_path_revert_head(the_repository)))
 +	if (!file_exists(git_path_cherry_pick_head(r)) &&
 +	    !file_exists(git_path_revert_head(r)))
  		return error(_("no cherry-pick or revert in progress"));
  	return run_command_v_opt(argv, RUN_GIT_CMD);
  }
  
 -static int commit_staged_changes(struct replay_opts *opts,
 +static int commit_staged_changes(struct repository *r,
 +				 struct replay_opts *opts,
  				 struct todo_list *todo_list)
  {
  	unsigned int flags = ALLOW_EMPTY | EDIT_MSG;
  	unsigned int final_fixup = 0, is_clean;
  
 -	if (has_unstaged_changes(1))
 +	if (has_unstaged_changes(r, 1))
  		return error(_("cannot rebase: You have unstaged changes."));
  
 -	is_clean = !has_uncommitted_changes(0);
 +	is_clean = !has_uncommitted_changes(r, 0);
  
  	if (file_exists(rebase_path_amend())) {
  		struct strbuf rev = STRBUF_INIT;
@@@ -3903,7 -3862,7 +3910,7 @@@
  				struct commit *commit;
  				const char *path = rebase_path_squash_msg();
  
 -				if (parse_head(&commit) ||
 +				if (parse_head(r, &commit) ||
  				    !(p = get_commit_buffer(commit, NULL)) ||
  				    write_message(p, strlen(p), path, 0)) {
  					unuse_commit_buffer(commit, p);
@@@ -3919,7 -3878,7 +3926,7 @@@
  	}
  
  	if (is_clean) {
 -		const char *cherry_pick_head = git_path_cherry_pick_head(the_repository);
 +		const char *cherry_pick_head = git_path_cherry_pick_head(r);
  
  		if (file_exists(cherry_pick_head) && unlink(cherry_pick_head))
  			return error(_("could not remove CHERRY_PICK_HEAD"));
@@@ -3927,7 -3886,7 +3934,7 @@@
  			return 0;
  	}
  
 -	if (run_git_commit(final_fixup ? NULL : rebase_path_message(),
 +	if (run_git_commit(r, final_fixup ? NULL : rebase_path_message(),
  			   opts, flags))
  		return error(_("could not commit staged changes."));
  	unlink(rebase_path_amend());
@@@ -3948,36 -3907,36 +3955,36 @@@
  	return 0;
  }
  
 -int sequencer_continue(struct replay_opts *opts)
 +int sequencer_continue(struct repository *r, struct replay_opts *opts)
  {
  	struct todo_list todo_list = TODO_LIST_INIT;
  	int res;
  
 -	if (read_and_refresh_cache(opts))
 +	if (read_and_refresh_cache(r, opts))
  		return -1;
  
  	if (read_populate_opts(opts))
  		return -1;
  	if (is_rebase_i(opts)) {
 -		if ((res = read_populate_todo(&todo_list, opts)))
 +		if ((res = read_populate_todo(r, &todo_list, opts)))
  			goto release_todo_list;
 -		if (commit_staged_changes(opts, &todo_list))
 +		if (commit_staged_changes(r, opts, &todo_list))
  			return -1;
  	} else if (!file_exists(get_todo_path(opts)))
 -		return continue_single_pick();
 -	else if ((res = read_populate_todo(&todo_list, opts)))
 +		return continue_single_pick(r);
 +	else if ((res = read_populate_todo(r, &todo_list, opts)))
  		goto release_todo_list;
  
  	if (!is_rebase_i(opts)) {
  		/* Verify that the conflict has been resolved */
 -		if (file_exists(git_path_cherry_pick_head(the_repository)) ||
 -		    file_exists(git_path_revert_head(the_repository))) {
 -			res = continue_single_pick();
 +		if (file_exists(git_path_cherry_pick_head(r)) ||
 +		    file_exists(git_path_revert_head(r))) {
 +			res = continue_single_pick(r);
  			if (res)
  				goto release_todo_list;
  		}
 -		if (index_differs_from("HEAD", NULL, 0)) {
 -			res = error_dirty_index(opts);
 +		if (index_differs_from(r, "HEAD", NULL, 0)) {
 +			res = error_dirty_index(r->index, opts);
  			goto release_todo_list;
  		}
  		todo_list.current++;
@@@ -3991,30 -3950,27 +3998,30 @@@
  		strbuf_release(&buf);
  	}
  
 -	res = pick_commits(&todo_list, opts);
 +	res = pick_commits(r, &todo_list, opts);
  release_todo_list:
  	todo_list_release(&todo_list);
  	return res;
  }
  
 -static int single_pick(struct commit *cmit, struct replay_opts *opts)
 +static int single_pick(struct repository *r,
 +		       struct commit *cmit,
 +		       struct replay_opts *opts)
  {
  	setenv(GIT_REFLOG_ACTION, action_name(opts), 0);
 -	return do_pick_commit(opts->action == REPLAY_PICK ?
 +	return do_pick_commit(r, opts->action == REPLAY_PICK ?
  		TODO_PICK : TODO_REVERT, cmit, opts, 0);
  }
  
 -int sequencer_pick_revisions(struct replay_opts *opts)
 +int sequencer_pick_revisions(struct repository *r,
 +			     struct replay_opts *opts)
  {
  	struct todo_list todo_list = TODO_LIST_INIT;
  	struct object_id oid;
  	int i, res;
  
  	assert(opts->revs);
 -	if (read_and_refresh_cache(opts))
 +	if (read_and_refresh_cache(r, opts))
  		return -1;
  
  	for (i = 0; i < opts->revs->pending.nr; i++) {
@@@ -4026,8 -3982,8 +4033,8 @@@
  			continue;
  
  		if (!get_oid(name, &oid)) {
 -			if (!lookup_commit_reference_gently(the_repository, &oid, 1)) {
 -				enum object_type type = oid_object_info(the_repository,
 +			if (!lookup_commit_reference_gently(r, &oid, 1)) {
 +				enum object_type type = oid_object_info(r,
  									&oid,
  									NULL);
  				return error(_("%s: can't cherry-pick a %s"),
@@@ -4056,7 -4012,7 +4063,7 @@@
  			return error(_("empty commit set passed"));
  		if (get_revision(opts->revs))
  			BUG("unexpected extra commit from walk");
 -		return single_pick(cmit, opts);
 +		return single_pick(r, cmit, opts);
  	}
  
  	/*
@@@ -4075,7 -4031,7 +4082,7 @@@
  	if (save_opts(opts))
  		return -1;
  	update_abort_safety_file();
 -	res = pick_commits(&todo_list, opts);
 +	res = pick_commits(r, &todo_list, opts);
  	todo_list_release(&todo_list);
  	return res;
  }
@@@ -4479,8 -4435,7 +4486,8 @@@ static int make_script_with_merges(stru
  	return 0;
  }
  
 -int sequencer_make_script(FILE *out, int argc, const char **argv,
 +int sequencer_make_script(struct repository *r, FILE *out,
 +			  int argc, const char **argv,
  			  unsigned flags)
  {
  	char *format = NULL;
@@@ -4492,7 -4447,7 +4499,7 @@@
  	const char *insn = flags & TODO_LIST_ABBREVIATE_CMDS ? "p" : "pick";
  	int rebase_merges = flags & TODO_LIST_REBASE_MERGES;
  
 -	repo_init_revisions(the_repository, &revs, NULL);
 +	repo_init_revisions(r, &revs, NULL);
  	revs.verbose_header = 1;
  	if (!rebase_merges)
  		revs.max_parents = 1;
@@@ -4545,8 -4500,7 +4552,8 @@@
   * Add commands after pick and (series of) squash/fixup commands
   * in the todo list.
   */
 -int sequencer_add_exec_commands(const char *commands)
 +int sequencer_add_exec_commands(struct repository *r,
 +				const char *commands)
  {
  	const char *todo_file = rebase_path_todo();
  	struct todo_list todo_list = TODO_LIST_INIT;
@@@ -4557,7 -4511,7 +4564,7 @@@
  	if (strbuf_read_file(&todo_list.buf, todo_file, 0) < 0)
  		return error(_("could not read '%s'."), todo_file);
  
 -	if (parse_insn_buffer(todo_list.buf.buf, &todo_list)) {
 +	if (parse_insn_buffer(r, todo_list.buf.buf, &todo_list)) {
  		todo_list_release(&todo_list);
  		return error(_("unusable todo list: '%s'"), todo_file);
  	}
@@@ -4602,7 -4556,7 +4609,7 @@@
  	return i;
  }
  
 -int transform_todos(unsigned flags)
 +int transform_todos(struct repository *r, unsigned flags)
  {
  	const char *todo_file = rebase_path_todo();
  	struct todo_list todo_list = TODO_LIST_INIT;
@@@ -4613,7 -4567,7 +4620,7 @@@
  	if (strbuf_read_file(&todo_list.buf, todo_file, 0) < 0)
  		return error(_("could not read '%s'."), todo_file);
  
 -	if (parse_insn_buffer(todo_list.buf.buf, &todo_list)) {
 +	if (parse_insn_buffer(r, todo_list.buf.buf, &todo_list)) {
  		todo_list_release(&todo_list);
  		return error(_("unusable todo list: '%s'"), todo_file);
  	}
@@@ -4682,7 -4636,7 +4689,7 @@@ define_commit_slab(commit_seen, unsigne
   * Check if there is an unrecognized command or a
   * bad SHA-1 in a command.
   */
 -int check_todo_list(void)
 +int check_todo_list(struct repository *r)
  {
  	enum missing_commit_check_level check_level = get_missing_commit_check_level();
  	struct strbuf todo_file = STRBUF_INIT;
@@@ -4699,7 -4653,7 +4706,7 @@@
  		goto leave_check;
  	}
  	advise_to_edit_todo = res =
 -		parse_insn_buffer(todo_list.buf.buf, &todo_list);
 +		parse_insn_buffer(r, todo_list.buf.buf, &todo_list);
  
  	if (res || check_level == MISSING_COMMIT_CHECK_IGNORE)
  		goto leave_check;
@@@ -4718,7 -4672,7 +4725,7 @@@
  		goto leave_check;
  	}
  	strbuf_release(&todo_file);
 -	res = !!parse_insn_buffer(todo_list.buf.buf, &todo_list);
 +	res = !!parse_insn_buffer(r, todo_list.buf.buf, &todo_list);
  
  	/* Find commits in git-rebase-todo.backup yet unseen */
  	for (i = todo_list.nr - 1; i >= 0; i--) {
@@@ -4782,7 -4736,7 +4789,7 @@@ static int rewrite_file(const char *pat
  }
  
  /* skip picking commits whose parents are unchanged */
 -static int skip_unnecessary_picks(struct object_id *output_oid)
 +static int skip_unnecessary_picks(struct repository *r, struct object_id *output_oid)
  {
  	const char *todo_file = rebase_path_todo();
  	struct strbuf buf = STRBUF_INIT;
@@@ -4800,7 -4754,7 +4807,7 @@@
  
  	if (strbuf_read_file_or_whine(&todo_list.buf, todo_file) < 0)
  		return -1;
 -	if (parse_insn_buffer(todo_list.buf.buf, &todo_list) < 0) {
 +	if (parse_insn_buffer(r, todo_list.buf.buf, &todo_list) < 0) {
  		todo_list_release(&todo_list);
  		return -1;
  	}
@@@ -4861,7 -4815,7 +4868,7 @@@
  	return 0;
  }
  
 -int complete_action(struct replay_opts *opts, unsigned flags,
 +int complete_action(struct repository *r, struct replay_opts *opts, unsigned flags,
  		    const char *shortrevisions, const char *onto_name,
  		    const char *onto, const char *orig_head, const char *cmd,
  		    unsigned autosquash)
@@@ -4879,16 -4833,16 +4886,16 @@@
  	    write_message("noop\n", 5, todo_file, 0))
  		return -1;
  
 -	if (autosquash && rearrange_squash())
 +	if (autosquash && rearrange_squash(r))
  		return -1;
  
  	if (cmd && *cmd)
 -		sequencer_add_exec_commands(cmd);
 +		sequencer_add_exec_commands(r, cmd);
  
  	if (strbuf_read_file(buf, todo_file, 0) < 0)
  		return error_errno(_("could not read '%s'."), todo_file);
  
 -	if (parse_insn_buffer(buf->buf, &todo_list)) {
 +	if (parse_insn_buffer(r, buf->buf, &todo_list)) {
  		todo_list_release(&todo_list);
  		return error(_("unusable todo list: '%s'"), todo_file);
  	}
@@@ -4917,7 -4871,7 +4924,7 @@@
  		return error(_("could not copy '%s' to '%s'."), todo_file,
  			     rebase_path_todo_backup());
  
 -	if (transform_todos(flags | TODO_LIST_SHORTEN_IDS))
 +	if (transform_todos(r, flags | TODO_LIST_SHORTEN_IDS))
  		return error(_("could not transform the todo list"));
  
  	strbuf_reset(buf);
@@@ -4941,24 -4895,24 +4948,24 @@@
  
  	todo_list_release(&todo_list);
  
 -	if (check_todo_list()) {
 +	if (check_todo_list(r)) {
  		checkout_onto(opts, onto_name, onto, orig_head);
  		return -1;
  	}
  
 -	if (transform_todos(flags & ~(TODO_LIST_SHORTEN_IDS)))
 +	if (transform_todos(r, flags & ~(TODO_LIST_SHORTEN_IDS)))
  		return error(_("could not transform the todo list"));
  
 -	if (opts->allow_ff && skip_unnecessary_picks(&oid))
 +	if (opts->allow_ff && skip_unnecessary_picks(r, &oid))
  		return error(_("could not skip unnecessary pick commands"));
  
  	if (checkout_onto(opts, onto_name, oid_to_hex(&oid), orig_head))
  		return -1;
  
 -	if (require_clean_work_tree("rebase", "", 1, 1))
 +	if (require_clean_work_tree(r, "rebase", "", 1, 1))
  		return -1;
  
 -	return sequencer_continue(opts);
 +	return sequencer_continue(r, opts);
  }
  
  struct subject2item_entry {
@@@ -4985,7 -4939,7 +4992,7 @@@ define_commit_slab(commit_todo_item, st
   * message will have to be retrieved from the commit (as the oneline in the
   * script cannot be trusted) in order to normalize the autosquash arrangement.
   */
 -int rearrange_squash(void)
 +int rearrange_squash(struct repository *r)
  {
  	const char *todo_file = rebase_path_todo();
  	struct todo_list todo_list = TODO_LIST_INIT;
@@@ -4996,7 -4950,7 +5003,7 @@@
  
  	if (strbuf_read_file_or_whine(&todo_list.buf, todo_file) < 0)
  		return -1;
 -	if (parse_insn_buffer(todo_list.buf.buf, &todo_list) < 0) {
 +	if (parse_insn_buffer(r, todo_list.buf.buf, &todo_list) < 0) {
  		todo_list_release(&todo_list);
  		return -1;
  	}
diff --combined sequencer.h
index 9d83f0f3e9,1f865dae26..5d7bc04751
--- a/sequencer.h
+++ b/sequencer.h
@@@ -5,7 -5,6 +5,7 @@@
  #include "strbuf.h"
  
  struct commit;
 +struct repository;
  
  const char *git_path_commit_editmsg(void);
  const char *git_path_seq_dir(void);
@@@ -40,6 -39,7 +40,7 @@@ struct replay_opts 
  	int allow_empty_message;
  	int keep_redundant_commits;
  	int verbose;
+ 	int reschedule_failed_exec;
  
  	int mainline;
  
@@@ -75,10 -75,9 +76,10 @@@ int write_message(const void *buf, size
  
  /* Call this to setup defaults before parsing command line options */
  void sequencer_init_config(struct replay_opts *opts);
 -int sequencer_pick_revisions(struct replay_opts *opts);
 -int sequencer_continue(struct replay_opts *opts);
 -int sequencer_rollback(struct replay_opts *opts);
 +int sequencer_pick_revisions(struct repository *repo,
 +			     struct replay_opts *opts);
 +int sequencer_continue(struct repository *repo, struct replay_opts *opts);
 +int sequencer_rollback(struct repository *repo, struct replay_opts *opts);
  int sequencer_remove_state(struct replay_opts *opts);
  
  #define TODO_LIST_KEEP_EMPTY (1U << 0)
@@@ -91,19 -90,18 +92,19 @@@
   * commits should be rebased onto the new base, this flag needs to be passed.
   */
  #define TODO_LIST_REBASE_COUSINS (1U << 4)
 -int sequencer_make_script(FILE *out, int argc, const char **argv,
 +int sequencer_make_script(struct repository *repo, FILE *out,
 +			  int argc, const char **argv,
  			  unsigned flags);
  
 -int sequencer_add_exec_commands(const char *command);
 -int transform_todos(unsigned flags);
 +int sequencer_add_exec_commands(struct repository *r, const char *command);
 +int transform_todos(struct repository *r, unsigned flags);
  enum missing_commit_check_level get_missing_commit_check_level(void);
 -int check_todo_list(void);
 -int complete_action(struct replay_opts *opts, unsigned flags,
 +int check_todo_list(struct repository *r);
 +int complete_action(struct repository *r, struct replay_opts *opts, unsigned flags,
  		    const char *shortrevisions, const char *onto_name,
  		    const char *onto, const char *orig_head, const char *cmd,
  		    unsigned autosquash);
 -int rearrange_squash(void);
 +int rearrange_squash(struct repository *r);
  
  extern const char sign_off_header[];
  
@@@ -115,7 -113,7 +116,7 @@@
   */
  void append_signoff(struct strbuf *msgbuf, size_t ignore_footer, unsigned flag);
  
 -void append_conflicts_hint(struct strbuf *msgbuf);
 +void append_conflicts_hint(struct index_state *istate, struct strbuf *msgbuf);
  int message_is_empty(const struct strbuf *sb,
  		     enum commit_msg_cleanup_mode cleanup_mode);
  int template_untouched(const struct strbuf *sb, const char *template_file,
@@@ -131,9 -129,7 +132,9 @@@ int prepare_branch_to_be_rebased(struc
  
  #define SUMMARY_INITIAL_COMMIT   (1 << 0)
  #define SUMMARY_SHOW_AUTHOR_DATE (1 << 1)
 -void print_commit_summary(const char *prefix, const struct object_id *oid,
 +void print_commit_summary(struct repository *repo,
 +			  const char *prefix,
 +			  const struct object_id *oid,
  			  unsigned int flags);
  
  int read_author_script(const char *path, char **name, char **email, char **date,