builtin-read-tree.c: avoid tree_entry_list in prime_cache_tree_rec()
[git/git.git] / fetch.c
CommitLineData
215a7ad1 1#include "fetch.h"
4250a5e5
DB
2
3#include "cache.h"
4#include "commit.h"
5#include "tree.h"
3173bd49
DB
6#include "tag.h"
7#include "blob.h"
cd541a68
DB
8#include "refs.h"
9
10const char *write_ref = NULL;
11
4250a5e5
DB
12int get_tree = 0;
13int get_history = 0;
14int get_all = 0;
e78d9772 15int get_verbosely = 0;
820eca68 16int get_recover = 0;
b2d62f16 17static unsigned char current_commit_sha1[20];
4250a5e5 18
1e8be59d
DB
19void pull_say(const char *fmt, const char *hex)
20{
e78d9772
JH
21 if (get_verbosely)
22 fprintf(stderr, fmt, hex);
23}
24
b2d62f16
JH
25static void report_missing(const char *what, const unsigned char *missing)
26{
27 char missing_hex[41];
28
29 strcpy(missing_hex, sha1_to_hex(missing));;
30 fprintf(stderr,
31 "Cannot obtain needed %s %s\nwhile processing commit %s.\n",
32 what, missing_hex, sha1_to_hex(current_commit_sha1));
33}
34
80077f07 35static int process(struct object *obj);
3173bd49 36
1e8be59d 37static int process_tree(struct tree *tree)
4250a5e5 38{
85d106c2 39 struct tree_entry_list *entry;
4250a5e5
DB
40
41 if (parse_tree(tree))
42 return -1;
43
85d106c2
JH
44 entry = tree->entries;
45 tree->entries = NULL;
46 while (entry) {
47 struct tree_entry_list *next = entry->next;
80077f07 48 if (process(entry->item.any))
4250a5e5 49 return -1;
d35bbe0b 50 free(entry->name);
85d106c2
JH
51 free(entry);
52 entry = next;
4250a5e5
DB
53 }
54 return 0;
55}
56
24451c31
SV
57#define COMPLETE (1U << 0)
58#define SEEN (1U << 1)
59#define TO_SCAN (1U << 2)
85d106c2 60
d0ac30f2 61static struct commit_list *complete = NULL;
22c6e1d0 62
1e8be59d 63static int process_commit(struct commit *commit)
4250a5e5 64{
1e8be59d 65 if (parse_commit(commit))
4250a5e5
DB
66 return -1;
67
22c6e1d0 68 while (complete && complete->item->date >= commit->date) {
d0ac30f2 69 pop_most_recent_commit(&complete, COMPLETE);
22c6e1d0 70 }
22c6e1d0 71
d0ac30f2 72 if (commit->object.flags & COMPLETE)
22c6e1d0
DB
73 return 0;
74
1e8be59d 75 memcpy(current_commit_sha1, commit->object.sha1, 20);
4250a5e5 76
85d106c2
JH
77 pull_say("walk %s\n", sha1_to_hex(commit->object.sha1));
78
4250a5e5 79 if (get_tree) {
80077f07 80 if (process(&commit->tree->object))
4250a5e5
DB
81 return -1;
82 if (!get_all)
83 get_tree = 0;
84 }
85 if (get_history) {
1e8be59d 86 struct commit_list *parents = commit->parents;
4250a5e5 87 for (; parents; parents = parents->next) {
80077f07 88 if (process(&parents->item->object))
4250a5e5
DB
89 return -1;
90 }
91 }
92 return 0;
93}
94
1e8be59d 95static int process_tag(struct tag *tag)
3173bd49 96{
1e8be59d 97 if (parse_tag(tag))
3173bd49 98 return -1;
80077f07 99 return process(tag->tagged);
3173bd49
DB
100}
101
1e8be59d
DB
102static struct object_list *process_queue = NULL;
103static struct object_list **process_queue_end = &process_queue;
104
f88fcf8b 105static int process_object(struct object *obj)
3173bd49 106{
f88fcf8b
DB
107 if (obj->type == commit_type) {
108 if (process_commit((struct commit *)obj))
109 return -1;
110 return 0;
111 }
112 if (obj->type == tree_type) {
113 if (process_tree((struct tree *)obj))
114 return -1;
115 return 0;
116 }
117 if (obj->type == blob_type) {
118 return 0;
119 }
120 if (obj->type == tag_type) {
121 if (process_tag((struct tag *)obj))
122 return -1;
3173bd49 123 return 0;
f88fcf8b
DB
124 }
125 return error("Unable to determine requirements "
126 "of type %s for %s",
127 obj->type, sha1_to_hex(obj->sha1));
128}
129
80077f07 130static int process(struct object *obj)
f88fcf8b 131{
a82d07e5
SV
132 if (obj->flags & SEEN)
133 return 0;
134 obj->flags |= SEEN;
135
80077f07 136 if (has_sha1_file(obj->sha1)) {
f88fcf8b 137 /* We already have it, so we should scan it now. */
85d106c2 138 obj->flags |= TO_SCAN;
7b64d06b
SV
139 } else {
140 if (obj->flags & COMPLETE)
141 return 0;
142 prefetch(obj->sha1);
f88fcf8b 143 }
7b64d06b 144
1e8be59d
DB
145 object_list_insert(obj, process_queue_end);
146 process_queue_end = &(*process_queue_end)->next;
1e8be59d
DB
147 return 0;
148}
149
150static int loop(void)
151{
85d106c2
JH
152 struct object_list *elem;
153
1e8be59d
DB
154 while (process_queue) {
155 struct object *obj = process_queue->item;
85d106c2
JH
156 elem = process_queue;
157 process_queue = elem->next;
158 free(elem);
1e8be59d
DB
159 if (!process_queue)
160 process_queue_end = &process_queue;
161
85d106c2
JH
162 /* If we are not scanning this object, we placed it in
163 * the queue because we needed to fetch it first.
164 */
165 if (! (obj->flags & TO_SCAN)) {
11f0dafe 166 if (fetch(obj->sha1)) {
85d106c2
JH
167 report_missing(obj->type
168 ? obj->type
169 : "object", obj->sha1);
170 return -1;
171 }
172 }
1e8be59d
DB
173 if (!obj->type)
174 parse_object(obj->sha1);
f88fcf8b
DB
175 if (process_object(obj))
176 return -1;
1e8be59d
DB
177 }
178 return 0;
3173bd49
DB
179}
180
cd541a68
DB
181static int interpret_target(char *target, unsigned char *sha1)
182{
183 if (!get_sha1_hex(target, sha1))
184 return 0;
185 if (!check_ref_format(target)) {
186 if (!fetch_ref(target, sha1)) {
187 return 0;
188 }
189 }
190 return -1;
191}
192
22c6e1d0
DB
193static int mark_complete(const char *path, const unsigned char *sha1)
194{
d0ac30f2
JH
195 struct commit *commit = lookup_commit_reference_gently(sha1, 1);
196 if (commit) {
197 commit->object.flags |= COMPLETE;
198 insert_by_date(commit, &complete);
22c6e1d0
DB
199 }
200 return 0;
201}
cd541a68 202
4250a5e5
DB
203int pull(char *target)
204{
4250a5e5 205 unsigned char sha1[20];
cd541a68 206
98533b90 207 save_commit_buffer = 0;
a95cb6fb 208 track_object_refs = 0;
cd541a68 209
84c667ff 210 if (!get_recover)
820eca68 211 for_each_ref(mark_complete);
22c6e1d0 212
cd541a68
DB
213 if (interpret_target(target, sha1))
214 return error("Could not interpret %s as something to pull",
215 target);
80077f07 216 if (process(lookup_unknown_object(sha1)))
1e8be59d
DB
217 return -1;
218 if (loop())
cd541a68
DB
219 return -1;
220
84c667ff
JH
221 if (write_ref)
222 write_ref_sha1_unlocked(write_ref, sha1);
cd541a68 223 return 0;
4250a5e5 224}