repository.c: replace hold_locked_index() with repo_hold_locked_index()
hold_locked_index() assumes the index path at $GIT_DIR/index. This is not good for places that take an arbitrary index_state instead of the_index, which is basically everywhere except builtin/. Replace it with repo_hold_locked_index(). hold_locked_index() remains as a wrapper around repo_hold_locked_index() to reduce changes in builtin/ Signed-off-by: Nguyễn Thái Ngọc Duy <pclouds@gmail.com> Signed-off-by: Junio C Hamano <gitster@pobox.com>
This commit is contained in:
parent
1d18d7581c
commit
3a95f31d1c
3
apply.c
3
apply.c
@ -4712,7 +4712,8 @@ static int apply_patch(struct apply_state *state,
|
|||||||
state->index_file,
|
state->index_file,
|
||||||
LOCK_DIE_ON_ERROR);
|
LOCK_DIE_ON_ERROR);
|
||||||
else
|
else
|
||||||
hold_locked_index(&state->lock_file, LOCK_DIE_ON_ERROR);
|
repo_hold_locked_index(state->repo, &state->lock_file,
|
||||||
|
LOCK_DIE_ON_ERROR);
|
||||||
}
|
}
|
||||||
|
|
||||||
if (state->check_index && read_apply_cache(state) < 0) {
|
if (state->check_index && read_apply_cache(state) < 0) {
|
||||||
|
2
cache.h
2
cache.h
@ -433,6 +433,7 @@ void validate_cache_entries(const struct index_state *istate);
|
|||||||
#define unmerge_cache_entry_at(at) unmerge_index_entry_at(&the_index, at)
|
#define unmerge_cache_entry_at(at) unmerge_index_entry_at(&the_index, at)
|
||||||
#define unmerge_cache(pathspec) unmerge_index(&the_index, pathspec)
|
#define unmerge_cache(pathspec) unmerge_index(&the_index, pathspec)
|
||||||
#define read_blob_data_from_cache(path, sz) read_blob_data_from_index(&the_index, (path), (sz))
|
#define read_blob_data_from_cache(path, sz) read_blob_data_from_index(&the_index, (path), (sz))
|
||||||
|
#define hold_locked_index(lock_file, flags) repo_hold_locked_index(the_repository, (lock_file), (flags))
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
#define TYPE_BITS 3
|
#define TYPE_BITS 3
|
||||||
@ -833,7 +834,6 @@ extern struct cache_entry *refresh_cache_entry(struct index_state *, struct cach
|
|||||||
*/
|
*/
|
||||||
extern void update_index_if_able(struct index_state *, struct lock_file *);
|
extern void update_index_if_able(struct index_state *, struct lock_file *);
|
||||||
|
|
||||||
extern int hold_locked_index(struct lock_file *, int);
|
|
||||||
extern void set_alternate_index_output(const char *);
|
extern void set_alternate_index_output(const char *);
|
||||||
|
|
||||||
extern int verify_index_checksum;
|
extern int verify_index_checksum;
|
||||||
|
@ -3643,7 +3643,7 @@ int merge_recursive_generic(struct merge_options *o,
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
hold_locked_index(&lock, LOCK_DIE_ON_ERROR);
|
repo_hold_locked_index(the_repository, &lock, LOCK_DIE_ON_ERROR);
|
||||||
clean = merge_recursive(o, head_commit, next_commit, ca,
|
clean = merge_recursive(o, head_commit, next_commit, ca,
|
||||||
result);
|
result);
|
||||||
if (clean < 0) {
|
if (clean < 0) {
|
||||||
|
2
merge.c
2
merge.c
@ -58,7 +58,7 @@ int checkout_fast_forward(struct repository *r,
|
|||||||
|
|
||||||
refresh_index(r->index, REFRESH_QUIET, NULL, NULL, NULL);
|
refresh_index(r->index, REFRESH_QUIET, NULL, NULL, NULL);
|
||||||
|
|
||||||
if (hold_locked_index(&lock_file, LOCK_REPORT_ON_ERROR) < 0)
|
if (repo_hold_locked_index(r, &lock_file, LOCK_REPORT_ON_ERROR) < 0)
|
||||||
return -1;
|
return -1;
|
||||||
|
|
||||||
memset(&trees, 0, sizeof(trees));
|
memset(&trees, 0, sizeof(trees));
|
||||||
|
@ -1733,11 +1733,6 @@ static int read_index_extension(struct index_state *istate,
|
|||||||
return 0;
|
return 0;
|
||||||
}
|
}
|
||||||
|
|
||||||
int hold_locked_index(struct lock_file *lk, int lock_flags)
|
|
||||||
{
|
|
||||||
return hold_lock_file_for_update(lk, get_index_file(), lock_flags);
|
|
||||||
}
|
|
||||||
|
|
||||||
int read_index(struct index_state *istate)
|
int read_index(struct index_state *istate)
|
||||||
{
|
{
|
||||||
return read_index_from(istate, get_index_file(), get_git_dir());
|
return read_index_from(istate, get_index_file(), get_git_dir());
|
||||||
|
10
repository.c
10
repository.c
@ -3,6 +3,7 @@
|
|||||||
#include "object-store.h"
|
#include "object-store.h"
|
||||||
#include "config.h"
|
#include "config.h"
|
||||||
#include "object.h"
|
#include "object.h"
|
||||||
|
#include "lockfile.h"
|
||||||
#include "submodule-config.h"
|
#include "submodule-config.h"
|
||||||
|
|
||||||
/* The main repository */
|
/* The main repository */
|
||||||
@ -263,3 +264,12 @@ int repo_read_index(struct repository *repo)
|
|||||||
|
|
||||||
return read_index_from(repo->index, repo->index_file, repo->gitdir);
|
return read_index_from(repo->index, repo->index_file, repo->gitdir);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
int repo_hold_locked_index(struct repository *repo,
|
||||||
|
struct lock_file *lf,
|
||||||
|
int flags)
|
||||||
|
{
|
||||||
|
if (!repo->index_file)
|
||||||
|
BUG("the repo hasn't been setup");
|
||||||
|
return hold_lock_file_for_update(lf, repo->index_file, flags);
|
||||||
|
}
|
||||||
|
@ -6,6 +6,7 @@
|
|||||||
struct config_set;
|
struct config_set;
|
||||||
struct git_hash_algo;
|
struct git_hash_algo;
|
||||||
struct index_state;
|
struct index_state;
|
||||||
|
struct lock_file;
|
||||||
struct raw_object_store;
|
struct raw_object_store;
|
||||||
struct submodule_cache;
|
struct submodule_cache;
|
||||||
|
|
||||||
@ -130,5 +131,8 @@ void repo_clear(struct repository *repo);
|
|||||||
* populated then the number of entries will simply be returned.
|
* populated then the number of entries will simply be returned.
|
||||||
*/
|
*/
|
||||||
int repo_read_index(struct repository *repo);
|
int repo_read_index(struct repository *repo);
|
||||||
|
int repo_hold_locked_index(struct repository *repo,
|
||||||
|
struct lock_file *lf,
|
||||||
|
int flags);
|
||||||
|
|
||||||
#endif /* REPOSITORY_H */
|
#endif /* REPOSITORY_H */
|
||||||
|
2
rerere.c
2
rerere.c
@ -705,7 +705,7 @@ static void update_paths(struct repository *r, struct string_list *update)
|
|||||||
struct lock_file index_lock = LOCK_INIT;
|
struct lock_file index_lock = LOCK_INIT;
|
||||||
int i;
|
int i;
|
||||||
|
|
||||||
hold_locked_index(&index_lock, LOCK_DIE_ON_ERROR);
|
repo_hold_locked_index(r, &index_lock, LOCK_DIE_ON_ERROR);
|
||||||
|
|
||||||
for (i = 0; i < update->nr; i++) {
|
for (i = 0; i < update->nr; i++) {
|
||||||
struct string_list_item *item = &update->items[i];
|
struct string_list_item *item = &update->items[i];
|
||||||
|
10
sequencer.c
10
sequencer.c
@ -540,7 +540,7 @@ static int do_recursive_merge(struct repository *r,
|
|||||||
char **xopt;
|
char **xopt;
|
||||||
struct lock_file index_lock = LOCK_INIT;
|
struct lock_file index_lock = LOCK_INIT;
|
||||||
|
|
||||||
if (hold_locked_index(&index_lock, LOCK_REPORT_ON_ERROR) < 0)
|
if (repo_hold_locked_index(r, &index_lock, LOCK_REPORT_ON_ERROR) < 0)
|
||||||
return -1;
|
return -1;
|
||||||
|
|
||||||
read_index(r->index);
|
read_index(r->index);
|
||||||
@ -1992,8 +1992,8 @@ static int read_and_refresh_cache(struct repository *r,
|
|||||||
struct replay_opts *opts)
|
struct replay_opts *opts)
|
||||||
{
|
{
|
||||||
struct lock_file index_lock = LOCK_INIT;
|
struct lock_file index_lock = LOCK_INIT;
|
||||||
int index_fd = hold_locked_index(&index_lock, 0);
|
int index_fd = repo_hold_locked_index(r, &index_lock, 0);
|
||||||
if (read_index(r->index) < 0) {
|
if (repo_read_index(r) < 0) {
|
||||||
rollback_lock_file(&index_lock);
|
rollback_lock_file(&index_lock);
|
||||||
return error(_("git %s: failed to read the index"),
|
return error(_("git %s: failed to read the index"),
|
||||||
_(action_name(opts)));
|
_(action_name(opts)));
|
||||||
@ -2978,7 +2978,7 @@ static int do_reset(struct repository *r,
|
|||||||
struct unpack_trees_options unpack_tree_opts;
|
struct unpack_trees_options unpack_tree_opts;
|
||||||
int ret = 0;
|
int ret = 0;
|
||||||
|
|
||||||
if (hold_locked_index(&lock, LOCK_REPORT_ON_ERROR) < 0)
|
if (repo_hold_locked_index(r, &lock, LOCK_REPORT_ON_ERROR) < 0)
|
||||||
return -1;
|
return -1;
|
||||||
|
|
||||||
if (len == 10 && !strncmp("[new root]", name, len)) {
|
if (len == 10 && !strncmp("[new root]", name, len)) {
|
||||||
@ -3096,7 +3096,7 @@ static int do_merge(struct repository *r,
|
|||||||
static struct lock_file lock;
|
static struct lock_file lock;
|
||||||
const char *p;
|
const char *p;
|
||||||
|
|
||||||
if (hold_locked_index(&lock, LOCK_REPORT_ON_ERROR) < 0) {
|
if (repo_hold_locked_index(r, &lock, LOCK_REPORT_ON_ERROR) < 0) {
|
||||||
ret = -1;
|
ret = -1;
|
||||||
goto leave_merge;
|
goto leave_merge;
|
||||||
}
|
}
|
||||||
|
@ -2375,7 +2375,7 @@ int require_clean_work_tree(struct repository *r,
|
|||||||
struct lock_file lock_file = LOCK_INIT;
|
struct lock_file lock_file = LOCK_INIT;
|
||||||
int err = 0, fd;
|
int err = 0, fd;
|
||||||
|
|
||||||
fd = hold_locked_index(&lock_file, 0);
|
fd = repo_hold_locked_index(r, &lock_file, 0);
|
||||||
refresh_index(r->index, REFRESH_QUIET, NULL, NULL, NULL);
|
refresh_index(r->index, REFRESH_QUIET, NULL, NULL, NULL);
|
||||||
if (0 <= fd)
|
if (0 <= fd)
|
||||||
update_index_if_able(r->index, &lock_file);
|
update_index_if_able(r->index, &lock_file);
|
||||||
|
Loading…
Reference in New Issue
Block a user