remote: move static variables into per-repository struct

remote.c does not works with non-the_repository because it stores its
state as static variables. To support non-the_repository, we can use a
per-repository struct for the remotes subsystem.

Prepare for this change by defining a struct remote_state that holds
the remotes subsystem state and move the static variables of remote.c
into the_repository->remote_state.

This introduces no behavioral or API changes.

Signed-off-by: Glen Choo <chooglen@google.com>
Reviewed-by: Jonathan Tan <jonathantanmy@google.com>
Signed-off-by: Junio C Hamano <gitster@pobox.com>
This commit is contained in:
Glen Choo 2021-11-17 16:53:22 -08:00 коммит произвёл Junio C Hamano
Родитель e083ef5d54
Коммит fd3cb0501e
4 изменённых файлов: 170 добавлений и 67 удалений

191
remote.c
Просмотреть файл

@ -21,33 +21,6 @@ struct counted_string {
size_t len; size_t len;
const char *s; const char *s;
}; };
struct rewrite {
const char *base;
size_t baselen;
struct counted_string *instead_of;
int instead_of_nr;
int instead_of_alloc;
};
struct rewrites {
struct rewrite **rewrite;
int rewrite_alloc;
int rewrite_nr;
};
static struct remote **remotes;
static int remotes_alloc;
static int remotes_nr;
static struct hashmap remotes_hash;
static struct branch **branches;
static int branches_alloc;
static int branches_nr;
static struct branch *current_branch;
static const char *pushremote_name;
static struct rewrites rewrites;
static struct rewrites rewrites_push;
static int valid_remote(const struct remote *remote) static int valid_remote(const struct remote *remote)
{ {
@ -94,14 +67,16 @@ static void add_pushurl(struct remote *remote, const char *pushurl)
static void add_pushurl_alias(struct remote *remote, const char *url) static void add_pushurl_alias(struct remote *remote, const char *url)
{ {
const char *pushurl = alias_url(url, &rewrites_push); const char *pushurl =
alias_url(url, &the_repository->remote_state->rewrites_push);
if (pushurl != url) if (pushurl != url)
add_pushurl(remote, pushurl); add_pushurl(remote, pushurl);
} }
static void add_url_alias(struct remote *remote, const char *url) static void add_url_alias(struct remote *remote, const char *url)
{ {
add_url(remote, alias_url(url, &rewrites)); add_url(remote,
alias_url(url, &the_repository->remote_state->rewrites));
add_pushurl_alias(remote, url); add_pushurl_alias(remote, url);
} }
@ -127,12 +102,6 @@ static int remotes_hash_cmp(const void *unused_cmp_data,
return strcmp(a->name, b->name); return strcmp(a->name, b->name);
} }
static inline void init_remotes_hash(void)
{
if (!remotes_hash.cmpfn)
hashmap_init(&remotes_hash, remotes_hash_cmp, NULL, 0);
}
static struct remote *make_remote(const char *name, int len) static struct remote *make_remote(const char *name, int len)
{ {
struct remote *ret; struct remote *ret;
@ -142,12 +111,12 @@ static struct remote *make_remote(const char *name, int len)
if (!len) if (!len)
len = strlen(name); len = strlen(name);
init_remotes_hash();
lookup.str = name; lookup.str = name;
lookup.len = len; lookup.len = len;
hashmap_entry_init(&lookup_entry, memhash(name, len)); hashmap_entry_init(&lookup_entry, memhash(name, len));
e = hashmap_get(&remotes_hash, &lookup_entry, &lookup); e = hashmap_get(&the_repository->remote_state->remotes_hash,
&lookup_entry, &lookup);
if (e) if (e)
return container_of(e, struct remote, ent); return container_of(e, struct remote, ent);
@ -158,15 +127,41 @@ static struct remote *make_remote(const char *name, int len)
refspec_init(&ret->push, REFSPEC_PUSH); refspec_init(&ret->push, REFSPEC_PUSH);
refspec_init(&ret->fetch, REFSPEC_FETCH); refspec_init(&ret->fetch, REFSPEC_FETCH);
ALLOC_GROW(remotes, remotes_nr + 1, remotes_alloc); ALLOC_GROW(the_repository->remote_state->remotes,
remotes[remotes_nr++] = ret; the_repository->remote_state->remotes_nr + 1,
the_repository->remote_state->remotes_alloc);
the_repository->remote_state
->remotes[the_repository->remote_state->remotes_nr++] = ret;
hashmap_entry_init(&ret->ent, lookup_entry.hash); hashmap_entry_init(&ret->ent, lookup_entry.hash);
if (hashmap_put_entry(&remotes_hash, ret, ent)) if (hashmap_put_entry(&the_repository->remote_state->remotes_hash, ret,
ent))
BUG("hashmap_put overwrote entry after hashmap_get returned NULL"); BUG("hashmap_put overwrote entry after hashmap_get returned NULL");
return ret; return ret;
} }
static void remote_clear(struct remote *remote)
{
int i;
free((char *)remote->name);
free((char *)remote->foreign_vcs);
for (i = 0; i < remote->url_nr; i++) {
free((char *)remote->url[i]);
}
FREE_AND_NULL(remote->pushurl);
for (i = 0; i < remote->pushurl_nr; i++) {
free((char *)remote->pushurl[i]);
}
FREE_AND_NULL(remote->pushurl);
free((char *)remote->receivepack);
free((char *)remote->uploadpack);
FREE_AND_NULL(remote->http_proxy);
FREE_AND_NULL(remote->http_proxy_authmethod);
}
static void add_merge(struct branch *branch, const char *name) static void add_merge(struct branch *branch, const char *name)
{ {
ALLOC_GROW(branch->merge_name, branch->merge_nr + 1, ALLOC_GROW(branch->merge_name, branch->merge_nr + 1,
@ -179,15 +174,20 @@ static struct branch *make_branch(const char *name, size_t len)
struct branch *ret; struct branch *ret;
int i; int i;
for (i = 0; i < branches_nr; i++) { for (i = 0; i < the_repository->remote_state->branches_nr; i++) {
if (!strncmp(name, branches[i]->name, len) && if (!strncmp(name,
!branches[i]->name[len]) the_repository->remote_state->branches[i]->name,
return branches[i]; len) &&
!the_repository->remote_state->branches[i]->name[len])
return the_repository->remote_state->branches[i];
} }
ALLOC_GROW(branches, branches_nr + 1, branches_alloc); ALLOC_GROW(the_repository->remote_state->branches,
the_repository->remote_state->branches_nr + 1,
the_repository->remote_state->branches_alloc);
CALLOC_ARRAY(ret, 1); CALLOC_ARRAY(ret, 1);
branches[branches_nr++] = ret; the_repository->remote_state
->branches[the_repository->remote_state->branches_nr++] = ret;
ret->name = xstrndup(name, len); ret->name = xstrndup(name, len);
ret->refname = xstrfmt("refs/heads/%s", ret->name); ret->refname = xstrfmt("refs/heads/%s", ret->name);
@ -327,12 +327,16 @@ static int handle_config(const char *key, const char *value, void *cb)
if (!strcmp(subkey, "insteadof")) { if (!strcmp(subkey, "insteadof")) {
if (!value) if (!value)
return config_error_nonbool(key); return config_error_nonbool(key);
rewrite = make_rewrite(&rewrites, name, namelen); rewrite = make_rewrite(
&the_repository->remote_state->rewrites, name,
namelen);
add_instead_of(rewrite, xstrdup(value)); add_instead_of(rewrite, xstrdup(value));
} else if (!strcmp(subkey, "pushinsteadof")) { } else if (!strcmp(subkey, "pushinsteadof")) {
if (!value) if (!value)
return config_error_nonbool(key); return config_error_nonbool(key);
rewrite = make_rewrite(&rewrites_push, name, namelen); rewrite = make_rewrite(
&the_repository->remote_state->rewrites_push,
name, namelen);
add_instead_of(rewrite, xstrdup(value)); add_instead_of(rewrite, xstrdup(value));
} }
} }
@ -342,7 +346,9 @@ static int handle_config(const char *key, const char *value, void *cb)
/* Handle remote.* variables */ /* Handle remote.* variables */
if (!name && !strcmp(subkey, "pushdefault")) if (!name && !strcmp(subkey, "pushdefault"))
return git_config_string(&pushremote_name, key, value); return git_config_string(
&the_repository->remote_state->pushremote_name, key,
value);
if (!name) if (!name)
return 0; return 0;
@ -425,18 +431,34 @@ static int handle_config(const char *key, const char *value, void *cb)
static void alias_all_urls(void) static void alias_all_urls(void)
{ {
int i, j; int i, j;
for (i = 0; i < remotes_nr; i++) { for (i = 0; i < the_repository->remote_state->remotes_nr; i++) {
int add_pushurl_aliases; int add_pushurl_aliases;
if (!remotes[i]) if (!the_repository->remote_state->remotes[i])
continue; continue;
for (j = 0; j < remotes[i]->pushurl_nr; j++) { for (j = 0;
remotes[i]->pushurl[j] = alias_url(remotes[i]->pushurl[j], &rewrites); j < the_repository->remote_state->remotes[i]->pushurl_nr;
j++) {
the_repository->remote_state->remotes[i]->pushurl[j] =
alias_url(
the_repository->remote_state->remotes[i]
->pushurl[j],
&the_repository->remote_state->rewrites);
} }
add_pushurl_aliases = remotes[i]->pushurl_nr == 0; add_pushurl_aliases =
for (j = 0; j < remotes[i]->url_nr; j++) { the_repository->remote_state->remotes[i]->pushurl_nr ==
0;
for (j = 0;
j < the_repository->remote_state->remotes[i]->url_nr;
j++) {
if (add_pushurl_aliases) if (add_pushurl_aliases)
add_pushurl_alias(remotes[i], remotes[i]->url[j]); add_pushurl_alias(
remotes[i]->url[j] = alias_url(remotes[i]->url[j], &rewrites); the_repository->remote_state->remotes[i],
the_repository->remote_state->remotes[i]
->url[j]);
the_repository->remote_state->remotes[i]
->url[j] = alias_url(
the_repository->remote_state->remotes[i]->url[j],
&the_repository->remote_state->rewrites);
} }
} }
} }
@ -450,12 +472,13 @@ static void read_config(void)
return; return;
loaded = 1; loaded = 1;
current_branch = NULL; the_repository->remote_state->current_branch = NULL;
if (startup_info->have_repository) { if (startup_info->have_repository) {
const char *head_ref = resolve_ref_unsafe("HEAD", 0, NULL, &flag); const char *head_ref = resolve_ref_unsafe("HEAD", 0, NULL, &flag);
if (head_ref && (flag & REF_ISSYMREF) && if (head_ref && (flag & REF_ISSYMREF) &&
skip_prefix(head_ref, "refs/heads/", &head_ref)) { skip_prefix(head_ref, "refs/heads/", &head_ref)) {
current_branch = make_branch(head_ref, strlen(head_ref)); the_repository->remote_state->current_branch =
make_branch(head_ref, strlen(head_ref));
} }
} }
git_config(handle_config, NULL); git_config(handle_config, NULL);
@ -493,10 +516,10 @@ const char *pushremote_for_branch(struct branch *branch, int *explicit)
*explicit = 1; *explicit = 1;
return branch->pushremote_name; return branch->pushremote_name;
} }
if (pushremote_name) { if (the_repository->remote_state->pushremote_name) {
if (explicit) if (explicit)
*explicit = 1; *explicit = 1;
return pushremote_name; return the_repository->remote_state->pushremote_name;
} }
return remote_for_branch(branch, explicit); return remote_for_branch(branch, explicit);
} }
@ -534,7 +557,8 @@ static struct remote *remote_get_1(const char *name,
if (name) if (name)
name_given = 1; name_given = 1;
else else
name = get_default(current_branch, &name_given); name = get_default(the_repository->remote_state->current_branch,
&name_given);
ret = make_remote(name, 0); ret = make_remote(name, 0);
if (valid_remote_nick(name) && have_git_dir()) { if (valid_remote_nick(name) && have_git_dir()) {
@ -573,11 +597,13 @@ int for_each_remote(each_remote_fn fn, void *priv)
{ {
int i, result = 0; int i, result = 0;
read_config(); read_config();
for (i = 0; i < remotes_nr && !result; i++) { for (i = 0; i < the_repository->remote_state->remotes_nr && !result;
struct remote *r = remotes[i]; i++) {
if (!r) struct remote *remote =
the_repository->remote_state->remotes[i];
if (!remote)
continue; continue;
result = fn(r, priv); result = fn(remote, priv);
} }
return result; return result;
} }
@ -1685,7 +1711,7 @@ struct branch *branch_get(const char *name)
read_config(); read_config();
if (!name || !*name || !strcmp(name, "HEAD")) if (!name || !*name || !strcmp(name, "HEAD"))
ret = current_branch; ret = the_repository->remote_state->current_branch;
else else
ret = make_branch(name, strlen(name)); ret = make_branch(name, strlen(name));
set_merge(ret); set_merge(ret);
@ -2585,3 +2611,34 @@ void apply_push_cas(struct push_cas_option *cas,
check_if_includes_upstream(ref); check_if_includes_upstream(ref);
} }
} }
struct remote_state *remote_state_new(void)
{
struct remote_state *r = xmalloc(sizeof(*r));
memset(r, 0, sizeof(*r));
hashmap_init(&r->remotes_hash, remotes_hash_cmp, NULL, 0);
return r;
}
void remote_state_clear(struct remote_state *remote_state)
{
int i;
for (i = 0; i < remote_state->remotes_nr; i++) {
remote_clear(remote_state->remotes[i]);
}
FREE_AND_NULL(remote_state->remotes);
remote_state->remotes_alloc = 0;
remote_state->remotes_nr = 0;
hashmap_clear_and_free(&remote_state->remotes_hash, struct remote, ent);
for (i = 0; i < remote_state->branches_nr; i++) {
FREE_AND_NULL(remote_state->branches[i]);
}
FREE_AND_NULL(remote_state->branches);
remote_state->branches_alloc = 0;
remote_state->branches_nr = 0;
}

Просмотреть файл

@ -23,6 +23,40 @@ enum {
REMOTE_BRANCHES REMOTE_BRANCHES
}; };
struct rewrite {
const char *base;
size_t baselen;
struct counted_string *instead_of;
int instead_of_nr;
int instead_of_alloc;
};
struct rewrites {
struct rewrite **rewrite;
int rewrite_alloc;
int rewrite_nr;
};
struct remote_state {
struct remote **remotes;
int remotes_alloc;
int remotes_nr;
struct hashmap remotes_hash;
struct branch **branches;
int branches_alloc;
int branches_nr;
struct branch *current_branch;
const char *pushremote_name;
struct rewrites rewrites;
struct rewrites rewrites_push;
};
void remote_state_clear(struct remote_state *remote_state);
struct remote_state *remote_state_new(void);
struct remote { struct remote {
struct hashmap_entry ent; struct hashmap_entry ent;

Просмотреть файл

@ -9,6 +9,7 @@
#include "config.h" #include "config.h"
#include "object.h" #include "object.h"
#include "lockfile.h" #include "lockfile.h"
#include "remote.h"
#include "submodule-config.h" #include "submodule-config.h"
#include "sparse-index.h" #include "sparse-index.h"
#include "promisor-remote.h" #include "promisor-remote.h"
@ -24,6 +25,7 @@ void initialize_the_repository(void)
the_repo.index = &the_index; the_repo.index = &the_index;
the_repo.objects = raw_object_store_new(); the_repo.objects = raw_object_store_new();
the_repo.remote_state = remote_state_new();
the_repo.parsed_objects = parsed_object_pool_new(); the_repo.parsed_objects = parsed_object_pool_new();
repo_set_hash_algo(&the_repo, GIT_HASH_SHA1); repo_set_hash_algo(&the_repo, GIT_HASH_SHA1);
@ -164,6 +166,7 @@ int repo_init(struct repository *repo,
repo->objects = raw_object_store_new(); repo->objects = raw_object_store_new();
repo->parsed_objects = parsed_object_pool_new(); repo->parsed_objects = parsed_object_pool_new();
repo->remote_state = remote_state_new();
if (repo_init_gitdir(repo, gitdir)) if (repo_init_gitdir(repo, gitdir))
goto error; goto error;
@ -270,6 +273,11 @@ void repo_clear(struct repository *repo)
promisor_remote_clear(repo->promisor_remote_config); promisor_remote_clear(repo->promisor_remote_config);
FREE_AND_NULL(repo->promisor_remote_config); FREE_AND_NULL(repo->promisor_remote_config);
} }
if (repo->remote_state) {
remote_state_clear(repo->remote_state);
FREE_AND_NULL(repo->remote_state);
}
} }
int repo_read_index(struct repository *repo) int repo_read_index(struct repository *repo)

Просмотреть файл

@ -11,6 +11,7 @@ struct pathspec;
struct raw_object_store; struct raw_object_store;
struct submodule_cache; struct submodule_cache;
struct promisor_remote_config; struct promisor_remote_config;
struct remote_state;
enum untracked_cache_setting { enum untracked_cache_setting {
UNTRACKED_CACHE_KEEP, UNTRACKED_CACHE_KEEP,
@ -127,6 +128,9 @@ struct repository {
*/ */
struct index_state *index; struct index_state *index;
/* Repository's remotes and associated structures. */
struct remote_state *remote_state;
/* Repository's current hash algorithm, as serialized on disk. */ /* Repository's current hash algorithm, as serialized on disk. */
const struct git_hash_algo *hash_algo; const struct git_hash_algo *hash_algo;