]>
Commit | Line | Data |
---|---|---|
94421474 JH |
1 | #include "cache.h" |
2 | #include "refs.h" | |
3 | #include "tag.h" | |
4 | #include "commit.h" | |
5 | #include "blob.h" | |
6 | #include "diff.h" | |
7 | #include "revision.h" | |
8 | #include "reachable.h" | |
9 | #include "cache-tree.h" | |
dc347195 | 10 | #include "progress.h" |
5f78a431 | 11 | #include "list-objects.h" |
7709f468 | 12 | #include "packfile.h" |
d0c39a49 | 13 | #include "worktree.h" |
a80d72db | 14 | #include "object-store.h" |
fde67d68 | 15 | #include "pack-bitmap.h" |
fb546d6e | 16 | #include "pack-mtimes.h" |
94421474 | 17 | |
0b26abc0 JK |
18 | struct connectivity_progress { |
19 | struct progress *progress; | |
20 | unsigned long count; | |
21 | }; | |
22 | ||
23 | static void update_progress(struct connectivity_progress *cp) | |
24 | { | |
25 | cp->count++; | |
26 | if ((cp->count & 1023) == 0) | |
27 | display_progress(cp->progress, cp->count); | |
28 | } | |
29 | ||
635170f2 MH |
30 | static int add_one_ref(const char *path, const struct object_id *oid, |
31 | int flag, void *cb_data) | |
94421474 | 32 | { |
94421474 | 33 | struct rev_info *revs = (struct rev_info *)cb_data; |
14886b40 | 34 | struct object *object; |
94421474 | 35 | |
14886b40 JS |
36 | if ((flag & REF_ISSYMREF) && (flag & REF_ISBROKEN)) { |
37 | warning("symbolic ref is dangling: %s", path); | |
38 | return 0; | |
39 | } | |
40 | ||
c251c83d | 41 | object = parse_object_or_die(oid, path); |
94421474 JH |
42 | add_pending_object(revs, object, ""); |
43 | ||
44 | return 0; | |
45 | } | |
46 | ||
5f78a431 JK |
47 | /* |
48 | * The traversal will have already marked us as SEEN, so we | |
49 | * only need to handle any progress reporting here. | |
50 | */ | |
de1e67d0 | 51 | static void mark_object(struct object *obj, const char *name, void *data) |
5f78a431 JK |
52 | { |
53 | update_progress(data); | |
54 | } | |
55 | ||
56 | static void mark_commit(struct commit *c, void *data) | |
57 | { | |
de1e67d0 | 58 | mark_object(&c->object, NULL, data); |
5f78a431 JK |
59 | } |
60 | ||
d3038d22 JK |
61 | struct recent_data { |
62 | struct rev_info *revs; | |
dddbad72 | 63 | timestamp_t timestamp; |
2fb90409 TB |
64 | report_recent_object_fn *cb; |
65 | int ignore_in_core_kept_packs; | |
d3038d22 JK |
66 | }; |
67 | ||
76c1d9a0 | 68 | static void add_recent_object(const struct object_id *oid, |
2fb90409 TB |
69 | struct packed_git *pack, |
70 | off_t offset, | |
dddbad72 | 71 | timestamp_t mtime, |
d3038d22 JK |
72 | struct recent_data *data) |
73 | { | |
74 | struct object *obj; | |
75 | enum object_type type; | |
76 | ||
77 | if (mtime <= data->timestamp) | |
78 | return; | |
79 | ||
80 | /* | |
81 | * We do not want to call parse_object here, because | |
82 | * inflating blobs and trees could be very expensive. | |
83 | * However, we do need to know the correct type for | |
84 | * later processing, and the revision machinery expects | |
85 | * commits and tags to have been parsed. | |
86 | */ | |
0df8e965 | 87 | type = oid_object_info(the_repository, oid, NULL); |
d3038d22 | 88 | if (type < 0) |
76c1d9a0 | 89 | die("unable to get object info for %s", oid_to_hex(oid)); |
d3038d22 JK |
90 | |
91 | switch (type) { | |
92 | case OBJ_TAG: | |
93 | case OBJ_COMMIT: | |
c251c83d | 94 | obj = parse_object_or_die(oid, NULL); |
d3038d22 JK |
95 | break; |
96 | case OBJ_TREE: | |
f86bcc7b | 97 | obj = (struct object *)lookup_tree(the_repository, oid); |
d3038d22 JK |
98 | break; |
99 | case OBJ_BLOB: | |
da14a7ff | 100 | obj = (struct object *)lookup_blob(the_repository, oid); |
d3038d22 JK |
101 | break; |
102 | default: | |
103 | die("unknown object type for %s: %s", | |
debca9d2 | 104 | oid_to_hex(oid), type_name(type)); |
d3038d22 JK |
105 | } |
106 | ||
107 | if (!obj) | |
76c1d9a0 | 108 | die("unable to lookup %s", oid_to_hex(oid)); |
d3038d22 JK |
109 | |
110 | add_pending_object(data->revs, obj, ""); | |
2fb90409 TB |
111 | if (data->cb) |
112 | data->cb(obj, pack, offset, mtime); | |
113 | } | |
114 | ||
115 | static int want_recent_object(struct recent_data *data, | |
116 | const struct object_id *oid) | |
117 | { | |
118 | if (data->ignore_in_core_kept_packs && | |
119 | has_object_kept_pack(oid, IN_CORE_KEEP_PACKS)) | |
120 | return 0; | |
121 | return 1; | |
d3038d22 JK |
122 | } |
123 | ||
76c1d9a0 | 124 | static int add_recent_loose(const struct object_id *oid, |
d3038d22 JK |
125 | const char *path, void *data) |
126 | { | |
127 | struct stat st; | |
2fb90409 TB |
128 | struct object *obj; |
129 | ||
130 | if (!want_recent_object(data, oid)) | |
131 | return 0; | |
132 | ||
133 | obj = lookup_object(the_repository, oid); | |
d3038d22 JK |
134 | |
135 | if (obj && obj->flags & SEEN) | |
136 | return 0; | |
137 | ||
138 | if (stat(path, &st) < 0) { | |
139 | /* | |
140 | * It's OK if an object went away during our iteration; this | |
141 | * could be due to a simultaneous repack. But anything else | |
142 | * we should abort, since we might then fail to mark objects | |
143 | * which should not be pruned. | |
144 | */ | |
145 | if (errno == ENOENT) | |
146 | return 0; | |
76c1d9a0 | 147 | return error_errno("unable to stat %s", oid_to_hex(oid)); |
d3038d22 JK |
148 | } |
149 | ||
2fb90409 | 150 | add_recent_object(oid, NULL, 0, st.st_mtime, data); |
d3038d22 JK |
151 | return 0; |
152 | } | |
153 | ||
76c1d9a0 | 154 | static int add_recent_packed(const struct object_id *oid, |
d3038d22 JK |
155 | struct packed_git *p, uint32_t pos, |
156 | void *data) | |
157 | { | |
2fb90409 | 158 | struct object *obj; |
fb546d6e | 159 | timestamp_t mtime = p->mtime; |
2fb90409 TB |
160 | |
161 | if (!want_recent_object(data, oid)) | |
162 | return 0; | |
163 | ||
164 | obj = lookup_object(the_repository, oid); | |
d3038d22 JK |
165 | |
166 | if (obj && obj->flags & SEEN) | |
167 | return 0; | |
fb546d6e TB |
168 | if (p->is_cruft) { |
169 | if (load_pack_mtimes(p) < 0) | |
170 | die(_("could not load cruft pack .mtimes")); | |
171 | mtime = nth_packed_mtime(p, pos); | |
172 | } | |
173 | add_recent_object(oid, p, nth_packed_object_offset(p, pos), mtime, data); | |
d3038d22 JK |
174 | return 0; |
175 | } | |
176 | ||
abcb8655 | 177 | int add_unseen_recent_objects_to_traversal(struct rev_info *revs, |
2fb90409 TB |
178 | timestamp_t timestamp, |
179 | report_recent_object_fn *cb, | |
180 | int ignore_in_core_kept_packs) | |
d3038d22 JK |
181 | { |
182 | struct recent_data data; | |
2fb90409 | 183 | enum for_each_object_flags flags; |
d3038d22 JK |
184 | int r; |
185 | ||
186 | data.revs = revs; | |
187 | data.timestamp = timestamp; | |
2fb90409 TB |
188 | data.cb = cb; |
189 | data.ignore_in_core_kept_packs = ignore_in_core_kept_packs; | |
d3038d22 | 190 | |
1385bb7b JK |
191 | r = for_each_loose_object(add_recent_loose, &data, |
192 | FOR_EACH_OBJECT_LOCAL_ONLY); | |
d3038d22 JK |
193 | if (r) |
194 | return r; | |
2fb90409 TB |
195 | |
196 | flags = FOR_EACH_OBJECT_LOCAL_ONLY | FOR_EACH_OBJECT_PACK_ORDER; | |
197 | if (ignore_in_core_kept_packs) | |
198 | flags |= FOR_EACH_OBJECT_SKIP_IN_CORE_KEPT_PACKS; | |
199 | ||
200 | return for_each_packed_object(add_recent_packed, &data, flags); | |
d3038d22 JK |
201 | } |
202 | ||
fde67d68 JK |
203 | static int mark_object_seen(const struct object_id *oid, |
204 | enum object_type type, | |
205 | int exclude, | |
206 | uint32_t name_hash, | |
207 | struct packed_git *found_pack, | |
208 | off_t found_offset) | |
209 | { | |
210 | struct object *obj = lookup_object_by_type(the_repository, oid, type); | |
211 | if (!obj) | |
212 | die("unable to create object '%s'", oid_to_hex(oid)); | |
213 | ||
214 | obj->flags |= SEEN; | |
215 | return 0; | |
216 | } | |
217 | ||
dc347195 | 218 | void mark_reachable_objects(struct rev_info *revs, int mark_reflog, |
dddbad72 | 219 | timestamp_t mark_recent, struct progress *progress) |
94421474 | 220 | { |
0b26abc0 | 221 | struct connectivity_progress cp; |
fde67d68 | 222 | struct bitmap_index *bitmap_git; |
0b26abc0 | 223 | |
94421474 JH |
224 | /* |
225 | * Set up revision parsing, and mark us as being interested | |
226 | * in all object types, not just commits. | |
227 | */ | |
228 | revs->tag_objects = 1; | |
229 | revs->blob_objects = 1; | |
230 | revs->tree_objects = 1; | |
231 | ||
232 | /* Add all refs from the index file */ | |
1be111d8 | 233 | add_index_objects_to_pending(revs, 0); |
94421474 JH |
234 | |
235 | /* Add all external refs */ | |
635170f2 | 236 | for_each_ref(add_one_ref, revs); |
94421474 | 237 | |
c40fdd01 | 238 | /* detached HEAD is not included in the list above */ |
635170f2 | 239 | head_ref(add_one_ref, revs); |
d0c39a49 | 240 | other_head_refs(add_one_ref, revs); |
c40fdd01 | 241 | |
eb8381c8 | 242 | /* Add all reflog info */ |
94421474 | 243 | if (mark_reflog) |
718ccc97 | 244 | add_reflogs_to_pending(revs, 0); |
94421474 | 245 | |
0b26abc0 JK |
246 | cp.progress = progress; |
247 | cp.count = 0; | |
248 | ||
09d4a79e | 249 | bitmap_git = prepare_bitmap_walk(revs, 0); |
fde67d68 | 250 | if (bitmap_git) { |
4eb707eb | 251 | traverse_bitmap_commit_list(bitmap_git, revs, mark_object_seen); |
fde67d68 | 252 | free_bitmap_index(bitmap_git); |
2ba582ba JK |
253 | } else { |
254 | if (prepare_revision_walk(revs)) | |
255 | die("revision walk setup failed"); | |
256 | traverse_commit_list(revs, mark_commit, mark_object, &cp); | |
fde67d68 JK |
257 | } |
258 | ||
d3038d22 JK |
259 | if (mark_recent) { |
260 | revs->ignore_missing_links = 1; | |
2fb90409 TB |
261 | if (add_unseen_recent_objects_to_traversal(revs, mark_recent, |
262 | NULL, 0)) | |
d3038d22 JK |
263 | die("unable to mark recent objects"); |
264 | if (prepare_revision_walk(revs)) | |
265 | die("revision walk setup failed"); | |
266 | traverse_commit_list(revs, mark_commit, mark_object, &cp); | |
267 | } | |
268 | ||
0b26abc0 | 269 | display_progress(cp.progress, cp.count); |
94421474 | 270 | } |