[thirdparty/git.git] / builtin / worktree.c

#include "cache.h"
#include "builtin.h"
#include "dir.h"
#include "parse-options.h"
#include "argv-array.h"
#include "run-command.h"
#include "sigchain.h"

static const char * const worktree_usage[] = {
	N_("git worktree add [<options>] <path> <branch>"),
	N_("git worktree prune [<options>]"),
	NULL
};

static int show_only;
static int verbose;
static unsigned long expire;

static int prune_worktree(const char *id, struct strbuf *reason)
{
	struct stat st;
	char *path;
	int fd, len;

	if (!is_directory(git_path("worktrees/%s", id))) {
		strbuf_addf(reason, _("Removing worktrees/%s: not a valid directory"), id);
		return 1;
	}
	if (file_exists(git_path("worktrees/%s/locked", id)))
		return 0;
	if (stat(git_path("worktrees/%s/gitdir", id), &st)) {
		strbuf_addf(reason, _("Removing worktrees/%s: gitdir file does not exist"), id);
		return 1;
	}
	fd = open(git_path("worktrees/%s/gitdir", id), O_RDONLY);
	if (fd < 0) {
		strbuf_addf(reason, _("Removing worktrees/%s: unable to read gitdir file (%s)"),
			    id, strerror(errno));
		return 1;
	}
	len = st.st_size;
	path = xmalloc(len + 1);
	read_in_full(fd, path, len);
	close(fd);
	while (len && (path[len - 1] == '\n' || path[len - 1] == '\r'))
		len--;
	if (!len) {
		strbuf_addf(reason, _("Removing worktrees/%s: invalid gitdir file"), id);
		free(path);
		return 1;
	}
	path[len] = '\0';
	if (!file_exists(path)) {
		struct stat st_link;
		free(path);
		/*
		 * the repo is moved manually and has not been
		 * accessed since?
		 */
		if (!stat(git_path("worktrees/%s/link", id), &st_link) &&
		    st_link.st_nlink > 1)
			return 0;
		if (st.st_mtime <= expire) {
			strbuf_addf(reason, _("Removing worktrees/%s: gitdir file points to non-existent location"), id);
			return 1;
		} else {
			return 0;
		}
	}
	free(path);
	return 0;
}

static void prune_worktrees(void)
{
	struct strbuf reason = STRBUF_INIT;
	struct strbuf path = STRBUF_INIT;
	DIR *dir = opendir(git_path("worktrees"));
	struct dirent *d;
	int ret;
	if (!dir)
		return;
	while ((d = readdir(dir)) != NULL) {
		if (!strcmp(d->d_name, ".") || !strcmp(d->d_name, ".."))
			continue;
		strbuf_reset(&reason);
		if (!prune_worktree(d->d_name, &reason))
			continue;
		if (show_only || verbose)
			printf("%s\n", reason.buf);
		if (show_only)
			continue;
		strbuf_reset(&path);
		strbuf_addstr(&path, git_path("worktrees/%s", d->d_name));
		ret = remove_dir_recursively(&path, 0);
		if (ret < 0 && errno == ENOTDIR)
			ret = unlink(path.buf);
		if (ret)
			error(_("failed to remove: %s"), strerror(errno));
	}
	closedir(dir);
	if (!show_only)
		rmdir(git_path("worktrees"));
	strbuf_release(&reason);
	strbuf_release(&path);
}

static int prune(int ac, const char **av, const char *prefix)
{
	struct option options[] = {
		OPT__DRY_RUN(&show_only, N_("do not remove, show only")),
		OPT__VERBOSE(&verbose, N_("report pruned objects")),
		OPT_EXPIRY_DATE(0, "expire", &expire,
				N_("expire objects older than <time>")),
		OPT_END()
	};

	expire = ULONG_MAX;
	ac = parse_options(ac, av, prefix, options, worktree_usage, 0);
	if (ac)
		usage_with_options(worktree_usage, options);
	prune_worktrees();
	return 0;
}

static char *junk_work_tree;
static char *junk_git_dir;
static int is_junk;
static pid_t junk_pid;

static void remove_junk(void)
{
	struct strbuf sb = STRBUF_INIT;
	if (!is_junk || getpid() != junk_pid)
		return;
	if (junk_git_dir) {
		strbuf_addstr(&sb, junk_git_dir);
		remove_dir_recursively(&sb, 0);
		strbuf_reset(&sb);
	}
	if (junk_work_tree) {
		strbuf_addstr(&sb, junk_work_tree);
		remove_dir_recursively(&sb, 0);
	}
	strbuf_release(&sb);
}

static void remove_junk_on_signal(int signo)
{
	remove_junk();
	sigchain_pop(signo);
	raise(signo);
}

static int add_worktree(const char *path, const char **child_argv)
{
	struct strbuf sb_git = STRBUF_INIT, sb_repo = STRBUF_INIT;
	struct strbuf sb = STRBUF_INIT;
	const char *name;
	struct stat st;
	struct child_process cp;
	int counter = 0, len, ret;
	unsigned char rev[20];

	if (file_exists(path) && !is_empty_dir(path))
		die(_("'%s' already exists"), path);

	len = strlen(path);
	while (len && is_dir_sep(path[len - 1]))
		len--;

	for (name = path + len - 1; name > path; name--)
		if (is_dir_sep(*name)) {
			name++;
			break;
		}
	strbuf_addstr(&sb_repo,
		      git_path("worktrees/%.*s", (int)(path + len - name), name));
	len = sb_repo.len;
	if (safe_create_leading_directories_const(sb_repo.buf))
		die_errno(_("could not create leading directories of '%s'"),
			  sb_repo.buf);
	while (!stat(sb_repo.buf, &st)) {
		counter++;
		strbuf_setlen(&sb_repo, len);
		strbuf_addf(&sb_repo, "%d", counter);
	}
	name = strrchr(sb_repo.buf, '/') + 1;

	junk_pid = getpid();
	atexit(remove_junk);
	sigchain_push_common(remove_junk_on_signal);

	if (mkdir(sb_repo.buf, 0777))
		die_errno(_("could not create directory of '%s'"), sb_repo.buf);
	junk_git_dir = xstrdup(sb_repo.buf);
	is_junk = 1;

	/*
	 * lock the incomplete repo so prune won't delete it, unlock
	 * after the preparation is over.
	 */
	strbuf_addf(&sb, "%s/locked", sb_repo.buf);
	write_file(sb.buf, 1, "initializing\n");

	strbuf_addf(&sb_git, "%s/.git", path);
	if (safe_create_leading_directories_const(sb_git.buf))
		die_errno(_("could not create leading directories of '%s'"),
			  sb_git.buf);
	junk_work_tree = xstrdup(path);

	strbuf_reset(&sb);
	strbuf_addf(&sb, "%s/gitdir", sb_repo.buf);
	write_file(sb.buf, 1, "%s\n", real_path(sb_git.buf));
	write_file(sb_git.buf, 1, "gitdir: %s/worktrees/%s\n",
		   real_path(get_git_common_dir()), name);
	/*
	 * This is to keep resolve_ref() happy. We need a valid HEAD
	 * or is_git_directory() will reject the directory. Moreover, HEAD
	 * in the new worktree must resolve to the same value as HEAD in
	 * the current tree since the command invoked to populate the new
	 * worktree will be handed the branch/ref specified by the user.
	 * For instance, if the user asks for the new worktree to be based
	 * at HEAD~5, then the resolved HEAD~5 in the new worktree must
	 * match the resolved HEAD~5 in the current tree in order to match
	 * the user's expectation.
	 */
	if (!resolve_ref_unsafe("HEAD", 0, rev, NULL))
		die(_("unable to resolve HEAD"));
	strbuf_reset(&sb);
	strbuf_addf(&sb, "%s/HEAD", sb_repo.buf);
	write_file(sb.buf, 1, "%s\n", sha1_to_hex(rev));
	strbuf_reset(&sb);
	strbuf_addf(&sb, "%s/commondir", sb_repo.buf);
	write_file(sb.buf, 1, "../..\n");

	fprintf_ln(stderr, _("Enter %s (identifier %s)"), path, name);

	setenv("GIT_CHECKOUT_NEW_WORKTREE", "1", 1);
	setenv(GIT_DIR_ENVIRONMENT, sb_git.buf, 1);
	setenv(GIT_WORK_TREE_ENVIRONMENT, path, 1);
	memset(&cp, 0, sizeof(cp));
	cp.git_cmd = 1;
	cp.argv = child_argv;
	ret = run_command(&cp);
	if (!ret) {
		is_junk = 0;
		free(junk_work_tree);
		free(junk_git_dir);
		junk_work_tree = NULL;
		junk_git_dir = NULL;
	}
	strbuf_reset(&sb);
	strbuf_addf(&sb, "%s/locked", sb_repo.buf);
	unlink_or_warn(sb.buf);
	strbuf_release(&sb);
	strbuf_release(&sb_repo);
	strbuf_release(&sb_git);
	return ret;
}

static int add(int ac, const char **av, const char *prefix)
{
	int force = 0, detach = 0;
	const char *new_branch = NULL, *new_branch_force = NULL;
	const char *path, *branch;
	struct argv_array cmd = ARGV_ARRAY_INIT;
	struct option options[] = {
		OPT__FORCE(&force, N_("checkout <branch> even if already checked out in other worktree")),
		OPT_STRING('b', NULL, &new_branch, N_("branch"),
			   N_("create a new branch")),
		OPT_STRING('B', NULL, &new_branch_force, N_("branch"),
			   N_("create or reset a branch")),
		OPT_BOOL(0, "detach", &detach, N_("detach HEAD at named commit")),
		OPT_END()
	};

	ac = parse_options(ac, av, prefix, options, worktree_usage, 0);
	if (new_branch && new_branch_force)
		die(_("-b and -B are mutually exclusive"));
	if (ac != 2)
		usage_with_options(worktree_usage, options);

	path = prefix ? prefix_filename(prefix, strlen(prefix), av[0]) : av[0];
	branch = av[1];

	argv_array_push(&cmd, "checkout");
	if (force)
		argv_array_push(&cmd, "--ignore-other-worktrees");
	if (new_branch)
		argv_array_pushl(&cmd, "-b", new_branch, NULL);
	if (new_branch_force)
		argv_array_pushl(&cmd, "-B", new_branch_force, NULL);
	if (detach)
		argv_array_push(&cmd, "--detach");
	argv_array_push(&cmd, branch);

	return add_worktree(path, cmd.argv);
}

int cmd_worktree(int ac, const char **av, const char *prefix)
{
	struct option options[] = {
		OPT_END()
	};

	if (ac < 2)
		usage_with_options(worktree_usage, options);
	if (!strcmp(av[1], "add"))
		return add(ac - 1, av + 1, prefix);
	if (!strcmp(av[1], "prune"))
		return prune(ac - 1, av + 1, prefix);
	usage_with_options(worktree_usage, options);
}
Commit	Line	Data
df0b6cfb NTND	1	#include "cache.h"
	2	#include "builtin.h"
	3	#include "dir.h"
	4	#include "parse-options.h"
fc56361f ES	5	#include "argv-array.h"
fc56361f ES	6	#include "run-command.h"
b979d950	7	#include "sigchain.h"
df0b6cfb NTND	8
df0b6cfb NTND	9	static const char * const worktree_usage[] = {
f4325444	10	N_("git worktree add [<options>] <path> <branch>"),
df0b6cfb NTND	11	N_("git worktree prune [<options>]"),
	12	NULL
	13	};
	14
	15	static int show_only;
	16	static int verbose;
	17	static unsigned long expire;
	18
	19	static int prune_worktree(const char id, struct strbuf reason)
	20	{
	21	struct stat st;
	22	char *path;
	23	int fd, len;
	24
	25	if (!is_directory(git_path("worktrees/%s", id))) {
	26	strbuf_addf(reason, _("Removing worktrees/%s: not a valid directory"), id);
	27	return 1;
	28	}
	29	if (file_exists(git_path("worktrees/%s/locked", id)))
	30	return 0;
	31	if (stat(git_path("worktrees/%s/gitdir", id), &st)) {
	32	strbuf_addf(reason, _("Removing worktrees/%s: gitdir file does not exist"), id);
	33	return 1;
	34	}
	35	fd = open(git_path("worktrees/%s/gitdir", id), O_RDONLY);
	36	if (fd < 0) {
	37	strbuf_addf(reason, _("Removing worktrees/%s: unable to read gitdir file (%s)"),
	38	id, strerror(errno));
	39	return 1;
	40	}
	41	len = st.st_size;
	42	path = xmalloc(len + 1);
	43	read_in_full(fd, path, len);
	44	close(fd);
	45	while (len && (path[len - 1] == '\n' \|\| path[len - 1] == '\r'))
	46	len--;
	47	if (!len) {
	48	strbuf_addf(reason, _("Removing worktrees/%s: invalid gitdir file"), id);
	49	free(path);
	50	return 1;
	51	}
	52	path[len] = '\0';
	53	if (!file_exists(path)) {
	54	struct stat st_link;
	55	free(path);
	56	/*
	57	* the repo is moved manually and has not been
	58	* accessed since?
	59	*/
	60	if (!stat(git_path("worktrees/%s/link", id), &st_link) &&
	61	st_link.st_nlink > 1)
	62	return 0;
	63	if (st.st_mtime <= expire) {
	64	strbuf_addf(reason, _("Removing worktrees/%s: gitdir file points to non-existent location"), id);
	65	return 1;
	66	} else {
	67	return 0;
	68	}
	69	}
	70	free(path);
	71	return 0;
	72	}
	73
	74	static void prune_worktrees(void)
75	{
76	struct strbuf reason = STRBUF_INIT;
77	struct strbuf path = STRBUF_INIT;
78	DIR *dir = opendir(git_path("worktrees"));
79	struct dirent *d;
80	int ret;
81	if (!dir)
82	return;
83	while ((d = readdir(dir)) != NULL) {
84	if (!strcmp(d->d_name, ".") \|\| !strcmp(d->d_name, ".."))
85	continue;
86	strbuf_reset(&reason);
87	if (!prune_worktree(d->d_name, &reason))
88	continue;
89	if (show_only \|\| verbose)
90	printf("%s\n", reason.buf);
91	if (show_only)
92	continue;
93	strbuf_reset(&path);
94	strbuf_addstr(&path, git_path("worktrees/%s", d->d_name));
95	ret = remove_dir_recursively(&path, 0);
96	if (ret < 0 && errno == ENOTDIR)
97	ret = unlink(path.buf);
98	if (ret)
99	error(_("failed to remove: %s"), strerror(errno));
100	}
101	closedir(dir);
102	if (!show_only)
103	rmdir(git_path("worktrees"));
104	strbuf_release(&reason);
105	strbuf_release(&path);
106	}
107
108	static int prune(int ac, const char *av, const char prefix)
109	{
110	struct option options[] = {
111	OPT__DRY_RUN(&show_only, N_("do not remove, show only")),
112	OPT__VERBOSE(&verbose, N_("report pruned objects")),
113	OPT_EXPIRY_DATE(0, "expire", &expire,
114	N_("expire objects older than <time>")),
115	OPT_END()
116	};
117
118	expire = ULONG_MAX;
119	ac = parse_options(ac, av, prefix, options, worktree_usage, 0);
120	if (ac)
121	usage_with_options(worktree_usage, options);
122	prune_worktrees();
123	return 0;
124	}
125
b979d950 ES	126	static char *junk_work_tree;
	127	static char *junk_git_dir;
	128	static int is_junk;
	129	static pid_t junk_pid;
	130
	131	static void remove_junk(void)
	132	{
	133	struct strbuf sb = STRBUF_INIT;
	134	if (!is_junk \|\| getpid() != junk_pid)
	135	return;
	136	if (junk_git_dir) {
	137	strbuf_addstr(&sb, junk_git_dir);
	138	remove_dir_recursively(&sb, 0);
	139	strbuf_reset(&sb);
	140	}
	141	if (junk_work_tree) {
	142	strbuf_addstr(&sb, junk_work_tree);
	143	remove_dir_recursively(&sb, 0);
	144	}
	145	strbuf_release(&sb);
	146	}
	147
	148	static void remove_junk_on_signal(int signo)
	149	{
	150	remove_junk();
	151	sigchain_pop(signo);
	152	raise(signo);
	153	}
	154
	155	static int add_worktree(const char path, const char *child_argv)
	156	{
	157	struct strbuf sb_git = STRBUF_INIT, sb_repo = STRBUF_INIT;
	158	struct strbuf sb = STRBUF_INIT;
	159	const char *name;
	160	struct stat st;
	161	struct child_process cp;
	162	int counter = 0, len, ret;
	163	unsigned char rev[20];
	164
	165	if (file_exists(path) && !is_empty_dir(path))
	166	die(_("'%s' already exists"), path);
	167
	168	len = strlen(path);
	169	while (len && is_dir_sep(path[len - 1]))
	170	len--;
	171
	172	for (name = path + len - 1; name > path; name--)
	173	if (is_dir_sep(*name)) {
	174	name++;
	175	break;
	176	}
	177	strbuf_addstr(&sb_repo,
	178	git_path("worktrees/%.*s", (int)(path + len - name), name));
	179	len = sb_repo.len;
	180	if (safe_create_leading_directories_const(sb_repo.buf))
	181	die_errno(_("could not create leading directories of '%s'"),
	182	sb_repo.buf);
	183	while (!stat(sb_repo.buf, &st)) {
	184	counter++;
	185	strbuf_setlen(&sb_repo, len);
	186	strbuf_addf(&sb_repo, "%d", counter);
	187	}
	188	name = strrchr(sb_repo.buf, '/') + 1;
	189
190	junk_pid = getpid();
191	atexit(remove_junk);
192	sigchain_push_common(remove_junk_on_signal);
193
194	if (mkdir(sb_repo.buf, 0777))
195	die_errno(_("could not create directory of '%s'"), sb_repo.buf);
196	junk_git_dir = xstrdup(sb_repo.buf);
197	is_junk = 1;
198
199	/*
200	* lock the incomplete repo so prune won't delete it, unlock
201	* after the preparation is over.
202	*/
203	strbuf_addf(&sb, "%s/locked", sb_repo.buf);
204	write_file(sb.buf, 1, "initializing\n");
205
206	strbuf_addf(&sb_git, "%s/.git", path);
207	if (safe_create_leading_directories_const(sb_git.buf))
208	die_errno(_("could not create leading directories of '%s'"),
209	sb_git.buf);
210	junk_work_tree = xstrdup(path);
211
212	strbuf_reset(&sb);
213	strbuf_addf(&sb, "%s/gitdir", sb_repo.buf);
214	write_file(sb.buf, 1, "%s\n", real_path(sb_git.buf));
215	write_file(sb_git.buf, 1, "gitdir: %s/worktrees/%s\n",
216	real_path(get_git_common_dir()), name);
217	/*
218	* This is to keep resolve_ref() happy. We need a valid HEAD
219	* or is_git_directory() will reject the directory. Moreover, HEAD
220	* in the new worktree must resolve to the same value as HEAD in
221	* the current tree since the command invoked to populate the new
222	* worktree will be handed the branch/ref specified by the user.
223	* For instance, if the user asks for the new worktree to be based
224	* at HEAD~5, then the resolved HEAD~5 in the new worktree must
225	* match the resolved HEAD~5 in the current tree in order to match
226	* the user's expectation.
227	*/
228	if (!resolve_ref_unsafe("HEAD", 0, rev, NULL))
229	die(_("unable to resolve HEAD"));
230	strbuf_reset(&sb);
231	strbuf_addf(&sb, "%s/HEAD", sb_repo.buf);
232	write_file(sb.buf, 1, "%s\n", sha1_to_hex(rev));
233	strbuf_reset(&sb);
234	strbuf_addf(&sb, "%s/commondir", sb_repo.buf);
235	write_file(sb.buf, 1, "../..\n");
236
237	fprintf_ln(stderr, _("Enter %s (identifier %s)"), path, name);
238
239	setenv("GIT_CHECKOUT_NEW_WORKTREE", "1", 1);
240	setenv(GIT_DIR_ENVIRONMENT, sb_git.buf, 1);
241	setenv(GIT_WORK_TREE_ENVIRONMENT, path, 1);
242	memset(&cp, 0, sizeof(cp));
243	cp.git_cmd = 1;
244	cp.argv = child_argv;
245	ret = run_command(&cp);
246	if (!ret) {
247	is_junk = 0;
248	free(junk_work_tree);
249	free(junk_git_dir);
250	junk_work_tree = NULL;
251	junk_git_dir = NULL;
252	}
253	strbuf_reset(&sb);
254	strbuf_addf(&sb, "%s/locked", sb_repo.buf);
255	unlink_or_warn(sb.buf);
256	strbuf_release(&sb);
257	strbuf_release(&sb_repo);
258	strbuf_release(&sb_git);
259	return ret;
260	}
261
fc56361f ES	262	static int add(int ac, const char *av, const char prefix)
fc56361f ES	263	{
39ecb274	264	int force = 0, detach = 0;
cbdf60fa	265	const char new_branch = NULL, new_branch_force = NULL;
fc56361f ES	266	const char path, branch;
	267	struct argv_array cmd = ARGV_ARRAY_INIT;
	268	struct option options[] = {
f4325444	269	OPT__FORCE(&force, N_("checkout <branch> even if already checked out in other worktree")),
cbdf60fa ES	270	OPT_STRING('b', NULL, &new_branch, N_("branch"),
	271	N_("create a new branch")),
	272	OPT_STRING('B', NULL, &new_branch_force, N_("branch"),
	273	N_("create or reset a branch")),
39ecb274	274	OPT_BOOL(0, "detach", &detach, N_("detach HEAD at named commit")),
fc56361f ES	275	OPT_END()
	276	};
	277
	278	ac = parse_options(ac, av, prefix, options, worktree_usage, 0);
cbdf60fa ES	279	if (new_branch && new_branch_force)
cbdf60fa ES	280	die(_("-b and -B are mutually exclusive"));
fc56361f ES	281	if (ac != 2)
	282	usage_with_options(worktree_usage, options);
	283
	284	path = prefix ? prefix_filename(prefix, strlen(prefix), av[0]) : av[0];
	285	branch = av[1];
	286
	287	argv_array_push(&cmd, "checkout");
f4325444 ES	288	if (force)
f4325444 ES	289	argv_array_push(&cmd, "--ignore-other-worktrees");
cbdf60fa ES	290	if (new_branch)
	291	argv_array_pushl(&cmd, "-b", new_branch, NULL);
	292	if (new_branch_force)
	293	argv_array_pushl(&cmd, "-B", new_branch_force, NULL);
39ecb274 ES	294	if (detach)
39ecb274 ES	295	argv_array_push(&cmd, "--detach");
fc56361f ES	296	argv_array_push(&cmd, branch);
fc56361f ES	297
b979d950	298	return add_worktree(path, cmd.argv);
fc56361f ES	299	}
fc56361f ES	300
df0b6cfb NTND	301	int cmd_worktree(int ac, const char *av, const char prefix)
	302	{
	303	struct option options[] = {
	304	OPT_END()
	305	};
	306
	307	if (ac < 2)
	308	usage_with_options(worktree_usage, options);
fc56361f ES	309	if (!strcmp(av[1], "add"))
fc56361f ES	310	return add(ac - 1, av + 1, prefix);
df0b6cfb NTND	311	if (!strcmp(av[1], "prune"))
	312	return prune(ac - 1, av + 1, prefix);
	313	usage_with_options(worktree_usage, options);
	314	}