14 int get_verbosely = 0;
16 static unsigned char current_commit_sha1[20];
18 void pull_say(const char *fmt, const char *hex)
21 fprintf(stderr, fmt, hex);
24 static void report_missing(const char *what, const unsigned char *missing)
28 strcpy(missing_hex, sha1_to_hex(missing));;
30 "Cannot obtain needed %s %s\nwhile processing commit %s.\n",
31 what, missing_hex, sha1_to_hex(current_commit_sha1));
34 static int process(struct object *obj);
36 static int process_tree(struct tree *tree)
38 struct tree_desc desc;
39 struct name_entry entry;
44 desc.buf = tree->buffer;
45 desc.size = tree->size;
46 while (tree_entry(&desc, &entry)) {
47 struct object *obj = NULL;
49 if (S_ISDIR(entry.mode)) {
50 struct tree *tree = lookup_tree(entry.sha1);
55 struct blob *blob = lookup_blob(entry.sha1);
59 if (!obj || process(obj))
68 #define COMPLETE (1U << 0)
69 #define SEEN (1U << 1)
70 #define TO_SCAN (1U << 2)
72 static struct commit_list *complete = NULL;
74 static int process_commit(struct commit *commit)
76 if (parse_commit(commit))
79 while (complete && complete->item->date >= commit->date) {
80 pop_most_recent_commit(&complete, COMPLETE);
83 if (commit->object.flags & COMPLETE)
86 memcpy(current_commit_sha1, commit->object.sha1, 20);
88 pull_say("walk %s\n", sha1_to_hex(commit->object.sha1));
91 if (process(&commit->tree->object))
97 struct commit_list *parents = commit->parents;
98 for (; parents; parents = parents->next) {
99 if (process(&parents->item->object))
106 static int process_tag(struct tag *tag)
110 return process(tag->tagged);
113 static struct object_list *process_queue = NULL;
114 static struct object_list **process_queue_end = &process_queue;
116 static int process_object(struct object *obj)
118 if (obj->type == OBJ_COMMIT) {
119 if (process_commit((struct commit *)obj))
123 if (obj->type == OBJ_TREE) {
124 if (process_tree((struct tree *)obj))
128 if (obj->type == OBJ_BLOB) {
131 if (obj->type == OBJ_TAG) {
132 if (process_tag((struct tag *)obj))
136 return error("Unable to determine requirements "
138 typename(obj->type), sha1_to_hex(obj->sha1));
141 static int process(struct object *obj)
143 if (obj->flags & SEEN)
147 if (has_sha1_file(obj->sha1)) {
148 /* We already have it, so we should scan it now. */
149 obj->flags |= TO_SCAN;
152 if (obj->flags & COMPLETE)
157 object_list_insert(obj, process_queue_end);
158 process_queue_end = &(*process_queue_end)->next;
162 static int loop(void)
164 struct object_list *elem;
166 while (process_queue) {
167 struct object *obj = process_queue->item;
168 elem = process_queue;
169 process_queue = elem->next;
172 process_queue_end = &process_queue;
174 /* If we are not scanning this object, we placed it in
175 * the queue because we needed to fetch it first.
177 if (! (obj->flags & TO_SCAN)) {
178 if (fetch(obj->sha1)) {
179 report_missing(typename(obj->type), obj->sha1);
184 parse_object(obj->sha1);
185 if (process_object(obj))
191 static int interpret_target(char *target, unsigned char *sha1)
193 if (!get_sha1_hex(target, sha1))
195 if (!check_ref_format(target)) {
196 if (!fetch_ref(target, sha1)) {
203 static int mark_complete(const char *path, const unsigned char *sha1)
205 struct commit *commit = lookup_commit_reference_gently(sha1, 1);
207 commit->object.flags |= COMPLETE;
208 insert_by_date(commit, &complete);
213 int pull(char *target, const char *write_ref,
214 const char *write_ref_log_details)
216 struct ref_lock *lock = NULL;
217 unsigned char sha1[20];
221 save_commit_buffer = 0;
222 track_object_refs = 0;
224 lock = lock_ref_sha1(write_ref, NULL, 0);
226 error("Can't lock ref %s", write_ref);
232 for_each_ref(mark_complete);
234 if (interpret_target(target, sha1)) {
235 error("Could not interpret %s as something to pull", target);
240 if (process(lookup_unknown_object(sha1))) {
252 if (write_ref_log_details) {
253 msg = xmalloc(strlen(write_ref_log_details) + 12);
254 sprintf(msg, "fetch from %s", write_ref_log_details);
258 ret = write_ref_sha1(lock, sha1, msg ? msg : "fetch (unknown)");