{
struct string_list config_info = STRING_LIST_INIT_NODUP;
struct string_list remote_info = STRING_LIST_INIT_DUP;
+ struct string_list accepted_remotes = STRING_LIST_INIT_NODUP;
struct store_info *store_info = NULL;
struct string_list_item *item;
bool reload_config = false;
- struct string_list accepted_filters = STRING_LIST_INIT_DUP;
enum accept_promisor accept = accept_from_server(repo);
if (accept == ACCEPT_NONE)
if (promisor_store_advertised_fields(advertised, store_info))
reload_config = true;
- strvec_push(accepted, advertised->name);
-
- /* Capture advertised filters for accepted remotes */
- if (advertised->filter) {
- struct string_list_item *i;
- i = string_list_append(&accepted_filters, advertised->name);
- i->util = xstrdup(advertised->filter);
- }
+ string_list_append(&accepted_remotes, advertised->name)->util = advertised;
+ } else {
+ promisor_info_free(advertised);
}
-
- promisor_info_free(advertised);
}
promisor_info_list_clear(&config_info);
if (reload_config)
repo_promisor_remote_reinit(repo);
- /* Apply accepted remote filters to the stable repo state */
- for_each_string_list_item(item, &accepted_filters) {
- struct promisor_remote *r = repo_promisor_remote_find(repo, item->string);
- if (r) {
- free(r->advertised_filter);
- r->advertised_filter = item->util;
- item->util = NULL;
- }
- }
+ /* Apply accepted remotes to the stable repo state */
+ for_each_string_list_item(item, &accepted_remotes) {
+ struct promisor_info *info = item->util;
+ struct promisor_remote *r = repo_promisor_remote_find(repo, info->name);
- string_list_clear(&accepted_filters, 1);
+ strvec_push(accepted, info->name);
- /* Mark the remotes as accepted in the repository state */
- for (size_t i = 0; i < accepted->nr; i++) {
- struct promisor_remote *r = repo_promisor_remote_find(repo, accepted->v[i]);
- if (r)
+ if (r) {
r->accepted = 1;
+ if (info->filter) {
+ free(r->advertised_filter);
+ r->advertised_filter = xstrdup(info->filter);
+ }
+ }
}
+
+ promisor_info_list_clear(&accepted_remotes);
}
void promisor_remote_reply(const char *info, char **accepted_out)