Function do_fetch_pack_v2

fetch-pack.c:1704–1952

}

static struct ref *do_fetch_pack_v2(struct fetch_pack_args *args,
				    int fd[2],
				    const struct ref *orig_ref,
				    struct ref **sought, int nr_sought,
				    struct oid_array *shallows,
				    struct shallow_info *si,
				    struct string_list *pack_lockfiles)
{
	struct repository *r = the_repository;
	struct fsck_options fsck_options;
	struct ref *ref = copy_ref_list(orig_ref);
	enum fetch_state state = FETCH_CHECK_LOCAL;
	struct oidset common = OIDSET_INIT;
	struct oidset negotiation_include_oids = OIDSET_INIT;
	struct packet_reader reader;
	int in_vain = 0, negotiation_started = 0;
	int negotiation_round = 0;
	int haves_to_send = INITIAL_FLUSH;
	struct fetch_negotiator negotiator_alloc;
	struct fetch_negotiator *negotiator;
	int seen_ack = 0;
	struct object_id common_oid;
	int received_ready = 0;
	struct string_list packfile_uris = STRING_LIST_INIT_DUP;
	int i;
	struct strvec index_pack_args = STRVEC_INIT;
	const char *promisor_remote_config;

	fsck_options_init(&fsck_options, the_repository, FSCK_OPTIONS_MISSING_GITMODULES);

	if (server_feature_v2("promisor-remote", &promisor_remote_config))
		promisor_remote_reply(promisor_remote_config, NULL);

	if (args->filter_options.choice == LOFC_AUTO) {
		struct strbuf errbuf = STRBUF_INIT;
		char *constructed_filter = promisor_remote_construct_filter(r);

		list_objects_filter_release(&args->filter_options);
		/* Disallow 'auto' as a result of the resolution of this 'auto' filter below */
		args->filter_options.allow_auto_filter = 0;

		if (constructed_filter &&
		    gently_parse_list_objects_filter(&args->filter_options,
						     constructed_filter,
						     &errbuf))
			die(_("couldn't resolve 'auto' filter '%s': %s"),
			    constructed_filter, errbuf.buf);

		free(constructed_filter);
		strbuf_release(&errbuf);
	}

	negotiator = &negotiator_alloc;
	if (args->refetch)
		fetch_negotiator_init_noop(negotiator);
	else
		fetch_negotiator_init(r, negotiator);