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