fetch.c 3.3 KB
Newer Older
1
/*
Edward Thomson committed
2
 * Copyright (C) the libgit2 contributors. All rights reserved.
3
 *
Vicent Marti committed
4 5
 * This file is part of libgit2, distributed under the GNU GPL v2 with
 * a Linking Exception. For full terms see the included COPYING file.
6 7 8 9
 */

#include "git2/oid.h"
#include "git2/refs.h"
Carlos Martín Nieto committed
10
#include "git2/revwalk.h"
11
#include "git2/transport.h"
12 13 14 15

#include "common.h"
#include "remote.h"
#include "refspec.h"
16
#include "pack.h"
17
#include "fetch.h"
18
#include "netops.h"
19 20
#include "repository.h"
#include "refs.h"
21

22
static int maybe_want(git_remote *remote, git_remote_head *head, git_odb *odb, git_refspec *tagspec)
23
{
24
	int match = 0;
25

26 27 28
	if (!git_reference_is_valid_name(head->name))
		return 0;

29
	if (remote->download_tags == GIT_REMOTE_DOWNLOAD_TAGS_ALL) {
30 31 32 33
		/*
		 * If tagopt is --tags, then we only use the default
		 * tags refspec and ignore the remote's
		 */
34
		if (git_refspec_src_matches(tagspec, head->name))
35
			match = 1;
36 37
		else
			return 0;
38
	} else if (git_remote__matching_refspec(remote, head->name))
39
			match = 1;
40

41 42
	if (!match)
		return 0;
43

44
	/* If we have the object, mark it so we don't ask for it */
45
	if (git_odb_exists(odb, &head->oid)) {
46
		head->local = 1;
47 48
		remote->need_pack = 0;
	}
49
	else
50
		remote->need_pack = 1;
51

52
	return git_vector_insert(&remote->refs, head);
53 54 55 56
}

static int filter_wants(git_remote *remote)
{
57
	git_remote_head **heads;
58
	git_refspec tagspec, head;
59 60 61
	int error = 0;
	git_odb *odb;
	size_t i, heads_len;
62

63 64
	git_vector_clear(&remote->refs);
	if ((error = git_refspec__parse(&tagspec, GIT_REFSPEC_TAGS, true)) < 0)
nulltoken committed
65
		return error;
66

67 68 69 70 71 72
	/*
	 * The fetch refspec can be NULL, and what this means is that the
	 * user didn't specify one. This is fine, as it means that we're
	 * not interested in any particular branch but just the remote's
	 * HEAD, which will be stored in FETCH_HEAD after the fetch.
	 */
73 74 75 76
	if (remote->active_refspecs.length == 0) {
		if ((error = git_refspec__parse(&head, "HEAD", true)) < 0)
			goto cleanup;

77 78 79 80
		error = git_refspec__dwim_one(&remote->active_refspecs, &head, &remote->refs);
		git_refspec__free(&head);

		if (error < 0)
81 82 83
			goto cleanup;
	}

84 85
	if (git_repository_odb__weakptr(&odb, remote->repo) < 0)
		goto cleanup;
86

87
	if (git_remote_ls((const git_remote_head ***)&heads, &heads_len, remote) < 0)
nulltoken committed
88
		goto cleanup;
89

90 91 92 93
	for (i = 0; i < heads_len; i++) {
		if ((error = maybe_want(remote, heads[i], odb, &tagspec)) < 0)
			break;
	}
nulltoken committed
94 95 96 97 98

cleanup:
	git_refspec__free(&tagspec);

	return error;
99
}
Carlos Martín Nieto committed
100 101 102 103 104 105

/*
 * In this first version, we push all our refs in and start sending
 * them out. When we get an ACK we hide that commit and continue
 * traversing until we're done
 */
106
int git_fetch_negotiate(git_remote *remote)
Carlos Martín Nieto committed
107
{
108
	git_transport *t = remote->transport;
109

110 111 112 113
	if (filter_wants(remote) < 0) {
		giterr_set(GITERR_NET, "Failed to filter the reference list for wants");
		return -1;
	}
114

Carlos Martín Nieto committed
115
	/* Don't try to negotiate when we don't want anything */
116
	if (!remote->need_pack)
117
		return 0;
118

Carlos Martín Nieto committed
119
	/*
120
	 * Now we have everything set up so we can start tell the
121
	 * server what we want and what we have.
122
	 */
123 124 125 126
	return t->negotiate_fetch(t,
		remote->repo,
		(const git_remote_head * const *)remote->refs.contents,
		remote->refs.length);
Carlos Martín Nieto committed
127 128
}

129
int git_fetch_download_pack(git_remote *remote)
130
{
131
	git_transport *t = remote->transport;
132

133
	if (!remote->need_pack)
134
		return 0;
135

136
	return t->download_pack(t, remote->repo, &remote->stats,
137
			remote->callbacks.transfer_progress, remote->callbacks.payload);
138
}