10 const char *write_ref
= NULL
;
12 const unsigned char *current_ref
= NULL
;
17 int get_verbosely
= 0;
18 static unsigned char current_commit_sha1
[20];
20 void pull_say(const char *fmt
, const char *hex
)
23 fprintf(stderr
, fmt
, hex
);
26 static void report_missing(const char *what
, const unsigned char *missing
)
30 strcpy(missing_hex
, sha1_to_hex(missing
));;
32 "Cannot obtain needed %s %s\nwhile processing commit %s.\n",
33 what
, missing_hex
, sha1_to_hex(current_commit_sha1
));
36 static int make_sure_we_have_it(const char *what
, unsigned char *sha1
)
40 if (!has_sha1_file(sha1
)) {
43 report_missing(what
, sha1
);
48 static int process(unsigned char *sha1
, const char *type
);
50 static int process_tree(struct tree
*tree
)
52 struct tree_entry_list
*entries
;
57 for (entries
= tree
->entries
; entries
; entries
= entries
->next
) {
58 if (process(entries
->item
.any
->sha1
,
59 entries
->directory
? tree_type
: blob_type
))
65 static int process_commit(struct commit
*commit
)
67 if (parse_commit(commit
))
70 memcpy(current_commit_sha1
, commit
->object
.sha1
, 20);
73 if (process(commit
->tree
->object
.sha1
, tree_type
))
79 struct commit_list
*parents
= commit
->parents
;
80 for (; parents
; parents
= parents
->next
) {
81 if (has_sha1_file(parents
->item
->object
.sha1
))
83 if (process(parents
->item
->object
.sha1
,
91 static int process_tag(struct tag
*tag
)
95 return process(tag
->tagged
->sha1
, NULL
);
98 static struct object_list
*process_queue
= NULL
;
99 static struct object_list
**process_queue_end
= &process_queue
;
101 static int process_object(struct object
*obj
)
103 if (obj
->type
== commit_type
) {
104 if (process_commit((struct commit
*)obj
))
108 if (obj
->type
== tree_type
) {
109 if (process_tree((struct tree
*)obj
))
113 if (obj
->type
== blob_type
) {
116 if (obj
->type
== tag_type
) {
117 if (process_tag((struct tag
*)obj
))
121 return error("Unable to determine requirements "
123 obj
->type
, sha1_to_hex(obj
->sha1
));
126 static int process(unsigned char *sha1
, const char *type
)
128 struct object
*obj
= lookup_object_type(sha1
, type
);
129 if (has_sha1_file(sha1
)) {
130 /* We already have it, so we should scan it now. */
131 return process_object(obj
);
133 if (object_list_contains(process_queue
, obj
))
135 object_list_insert(obj
, process_queue_end
);
136 process_queue_end
= &(*process_queue_end
)->next
;
138 //fprintf(stderr, "prefetch %s\n", sha1_to_hex(sha1));
144 static int loop(void)
146 while (process_queue
) {
147 struct object
*obj
= process_queue
->item
;
149 fprintf(stderr, "%d objects to pull\n",
150 object_list_length(process_queue));
152 process_queue
= process_queue
->next
;
154 process_queue_end
= &process_queue
;
156 //fprintf(stderr, "fetch %s\n", sha1_to_hex(obj->sha1));
158 if (make_sure_we_have_it(obj
->type
?: "object",
162 parse_object(obj
->sha1
);
163 if (process_object(obj
))
169 static int interpret_target(char *target
, unsigned char *sha1
)
171 if (!get_sha1_hex(target
, sha1
))
173 if (!check_ref_format(target
)) {
174 if (!fetch_ref(target
, sha1
)) {
182 int pull(char *target
)
184 unsigned char sha1
[20];
187 if (write_ref
&& current_ref
) {
188 fd
= lock_ref_sha1(write_ref
, current_ref
);
193 if (interpret_target(target
, sha1
))
194 return error("Could not interpret %s as something to pull",
196 if (process(sha1
, NULL
))
203 write_ref_sha1(write_ref
, fd
, sha1
);
205 write_ref_sha1_unlocked(write_ref
, sha1
);