Blame


1 d71d75ad 2017-11-05 stsp /*
2 5d56da81 2019-01-13 stsp * Copyright (c) 2018, 2019 Stefan Sperling <stsp@openbsd.org>
3 d71d75ad 2017-11-05 stsp *
4 d71d75ad 2017-11-05 stsp * Permission to use, copy, modify, and distribute this software for any
5 d71d75ad 2017-11-05 stsp * purpose with or without fee is hereby granted, provided that the above
6 d71d75ad 2017-11-05 stsp * copyright notice and this permission notice appear in all copies.
7 d71d75ad 2017-11-05 stsp *
8 d71d75ad 2017-11-05 stsp * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
9 d71d75ad 2017-11-05 stsp * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
10 d71d75ad 2017-11-05 stsp * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
11 d71d75ad 2017-11-05 stsp * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
12 d71d75ad 2017-11-05 stsp * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
13 d71d75ad 2017-11-05 stsp * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
14 d71d75ad 2017-11-05 stsp * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
15 d71d75ad 2017-11-05 stsp */
16 d71d75ad 2017-11-05 stsp
17 2178c42e 2018-04-22 stsp #include <sys/types.h>
18 0ffeb3c2 2017-11-26 stsp #include <sys/stat.h>
19 d1cda826 2017-11-06 stsp #include <sys/queue.h>
20 2178c42e 2018-04-22 stsp #include <sys/uio.h>
21 2178c42e 2018-04-22 stsp #include <sys/socket.h>
22 2178c42e 2018-04-22 stsp #include <sys/wait.h>
23 876c234b 2018-09-10 stsp #include <sys/syslimits.h>
24 b48e2ddb 2019-05-22 stsp #include <sys/resource.h>
25 d1cda826 2017-11-06 stsp
26 a1fd68d8 2018-01-12 stsp #include <errno.h>
27 2178c42e 2018-04-22 stsp #include <fcntl.h>
28 d71d75ad 2017-11-05 stsp #include <stdio.h>
29 ab9a70b2 2017-11-06 stsp #include <stdlib.h>
30 ab9a70b2 2017-11-06 stsp #include <string.h>
31 2178c42e 2018-04-22 stsp #include <stdint.h>
32 d71d75ad 2017-11-05 stsp #include <sha1.h>
33 ab9a70b2 2017-11-06 stsp #include <zlib.h>
34 ab9a70b2 2017-11-06 stsp #include <ctype.h>
35 ab9a70b2 2017-11-06 stsp #include <limits.h>
36 2178c42e 2018-04-22 stsp #include <imsg.h>
37 788c352e 2018-06-16 stsp #include <time.h>
38 d71d75ad 2017-11-05 stsp
39 ab9a70b2 2017-11-06 stsp #include "got_error.h"
40 d71d75ad 2017-11-05 stsp #include "got_object.h"
41 ab9a70b2 2017-11-06 stsp #include "got_repository.h"
42 511a516b 2018-05-19 stsp #include "got_opentemp.h"
43 324d37e7 2019-05-11 stsp #include "got_path.h"
44 d71d75ad 2017-11-05 stsp
45 718b3ab0 2018-03-17 stsp #include "got_lib_sha1.h"
46 718b3ab0 2018-03-17 stsp #include "got_lib_delta.h"
47 63581804 2018-07-09 stsp #include "got_lib_inflate.h"
48 718b3ab0 2018-03-17 stsp #include "got_lib_object.h"
49 2178c42e 2018-04-22 stsp #include "got_lib_privsep.h"
50 6bef87be 2018-09-11 stsp #include "got_lib_object_idcache.h"
51 6bef87be 2018-09-11 stsp #include "got_lib_object_cache.h"
52 ad242220 2018-09-08 stsp #include "got_lib_object_parse.h"
53 15a94983 2018-12-23 stsp #include "got_lib_pack.h"
54 7bb0daa1 2018-06-21 stsp #include "got_lib_repository.h"
55 1411938b 2018-02-12 stsp
56 ab9a70b2 2017-11-06 stsp #ifndef MIN
57 ab9a70b2 2017-11-06 stsp #define MIN(_a,_b) ((_a) < (_b) ? (_a) : (_b))
58 ab9a70b2 2017-11-06 stsp #endif
59 ef0981d5 2018-02-12 stsp
60 8bf5b3c9 2018-03-17 stsp struct got_object_id *
61 8bf5b3c9 2018-03-17 stsp got_object_id_dup(struct got_object_id *id1)
62 8bf5b3c9 2018-03-17 stsp {
63 8bf5b3c9 2018-03-17 stsp struct got_object_id *id2;
64 8bf5b3c9 2018-03-17 stsp
65 8bf5b3c9 2018-03-17 stsp id2 = malloc(sizeof(*id2));
66 8bf5b3c9 2018-03-17 stsp if (id2 == NULL)
67 8bf5b3c9 2018-03-17 stsp return NULL;
68 8bf5b3c9 2018-03-17 stsp memcpy(id2, id1, sizeof(*id2));
69 8bf5b3c9 2018-03-17 stsp return id2;
70 3235492e 2018-04-01 stsp }
71 3235492e 2018-04-01 stsp
72 3235492e 2018-04-01 stsp struct got_object_id *
73 3235492e 2018-04-01 stsp got_object_get_id(struct got_object *obj)
74 3235492e 2018-04-01 stsp {
75 6402fb3c 2018-09-15 stsp return &obj->id;
76 bacc9935 2018-05-20 stsp }
77 bacc9935 2018-05-20 stsp
78 bacc9935 2018-05-20 stsp const struct got_error *
79 bacc9935 2018-05-20 stsp got_object_get_id_str(char **outbuf, struct got_object *obj)
80 bacc9935 2018-05-20 stsp {
81 bacc9935 2018-05-20 stsp return got_object_id_str(outbuf, &obj->id);
82 a1fd68d8 2018-01-12 stsp }
83 d71d75ad 2017-11-05 stsp
84 15a94983 2018-12-23 stsp const struct got_error *
85 15a94983 2018-12-23 stsp got_object_get_type(int *type, struct got_repository *repo,
86 15a94983 2018-12-23 stsp struct got_object_id *id)
87 a1fd68d8 2018-01-12 stsp {
88 15a94983 2018-12-23 stsp const struct got_error *err = NULL;
89 15a94983 2018-12-23 stsp struct got_object *obj;
90 15a94983 2018-12-23 stsp
91 15a94983 2018-12-23 stsp err = got_object_open(&obj, repo, id);
92 15a94983 2018-12-23 stsp if (err)
93 15a94983 2018-12-23 stsp return err;
94 15a94983 2018-12-23 stsp
95 b107e67f 2018-01-19 stsp switch (obj->type) {
96 a1fd68d8 2018-01-12 stsp case GOT_OBJ_TYPE_COMMIT:
97 a1fd68d8 2018-01-12 stsp case GOT_OBJ_TYPE_TREE:
98 a1fd68d8 2018-01-12 stsp case GOT_OBJ_TYPE_BLOB:
99 b107e67f 2018-01-19 stsp case GOT_OBJ_TYPE_TAG:
100 15a94983 2018-12-23 stsp *type = obj->type;
101 15a94983 2018-12-23 stsp break;
102 96f5e8b3 2018-01-23 stsp default:
103 15a94983 2018-12-23 stsp err = got_error(GOT_ERR_OBJ_TYPE);
104 96f5e8b3 2018-01-23 stsp break;
105 d71d75ad 2017-11-05 stsp }
106 d71d75ad 2017-11-05 stsp
107 15a94983 2018-12-23 stsp got_object_close(obj);
108 15a94983 2018-12-23 stsp return err;
109 d71d75ad 2017-11-05 stsp }
110 ab9a70b2 2017-11-06 stsp
111 90bdb554 2019-04-11 stsp const struct got_error *
112 90bdb554 2019-04-11 stsp got_object_get_path(char **path, struct got_object_id *id,
113 90bdb554 2019-04-11 stsp struct got_repository *repo)
114 ab9a70b2 2017-11-06 stsp {
115 ab9a70b2 2017-11-06 stsp const struct got_error *err = NULL;
116 7a132809 2018-07-23 stsp char *hex = NULL;
117 41d2888b 2019-08-11 stsp char *path_objects;
118 e6b1056e 2018-04-22 stsp
119 e6b1056e 2018-04-22 stsp *path = NULL;
120 ab9a70b2 2017-11-06 stsp
121 41d2888b 2019-08-11 stsp path_objects = got_repo_get_path_objects(repo);
122 ab9a70b2 2017-11-06 stsp if (path_objects == NULL)
123 638f9024 2019-05-13 stsp return got_error_from_errno("got_repo_get_path_objects");
124 ab9a70b2 2017-11-06 stsp
125 ef0981d5 2018-02-12 stsp err = got_object_id_str(&hex, id);
126 ef0981d5 2018-02-12 stsp if (err)
127 7a132809 2018-07-23 stsp goto done;
128 ab9a70b2 2017-11-06 stsp
129 d1cda826 2017-11-06 stsp if (asprintf(path, "%s/%.2x/%s", path_objects,
130 d1cda826 2017-11-06 stsp id->sha1[0], hex + 2) == -1)
131 638f9024 2019-05-13 stsp err = got_error_from_errno("asprintf");
132 ab9a70b2 2017-11-06 stsp
133 7a132809 2018-07-23 stsp done:
134 ef0981d5 2018-02-12 stsp free(hex);
135 d1cda826 2017-11-06 stsp free(path_objects);
136 d1cda826 2017-11-06 stsp return err;
137 d1cda826 2017-11-06 stsp }
138 d1cda826 2017-11-06 stsp
139 4ee4114f 2018-01-23 stsp static const struct got_error *
140 4796fb13 2018-12-23 stsp open_loose_object(int *fd, struct got_object_id *id,
141 4796fb13 2018-12-23 stsp struct got_repository *repo)
142 d1cda826 2017-11-06 stsp {
143 d1cda826 2017-11-06 stsp const struct got_error *err = NULL;
144 a1fd68d8 2018-01-12 stsp char *path;
145 6c00b545 2018-01-17 stsp
146 90bdb554 2019-04-11 stsp err = got_object_get_path(&path, id, repo);
147 d1cda826 2017-11-06 stsp if (err)
148 d1cda826 2017-11-06 stsp return err;
149 a5b57ccf 2019-04-11 stsp *fd = open(path, O_RDONLY | O_NOFOLLOW);
150 d5003b79 2018-04-22 stsp if (*fd == -1) {
151 e82b1d81 2019-07-27 stsp err = got_error_from_errno2("open", path);
152 6c00b545 2018-01-17 stsp goto done;
153 a1fd68d8 2018-01-12 stsp }
154 4558fcd4 2018-01-14 stsp done:
155 4558fcd4 2018-01-14 stsp free(path);
156 2090a03d 2018-09-09 stsp return err;
157 2090a03d 2018-09-09 stsp }
158 2090a03d 2018-09-09 stsp
159 2090a03d 2018-09-09 stsp static const struct got_error *
160 2090a03d 2018-09-09 stsp get_packfile_path(char **path_packfile, struct got_packidx *packidx)
161 2090a03d 2018-09-09 stsp {
162 2090a03d 2018-09-09 stsp size_t size;
163 2090a03d 2018-09-09 stsp
164 2090a03d 2018-09-09 stsp /* Packfile path contains ".pack" instead of ".idx", so add one byte. */
165 2090a03d 2018-09-09 stsp size = strlen(packidx->path_packidx) + 2;
166 2090a03d 2018-09-09 stsp if (size < GOT_PACKFILE_NAMELEN + 1)
167 2090a03d 2018-09-09 stsp return got_error(GOT_ERR_BAD_PATH);
168 2090a03d 2018-09-09 stsp
169 08451938 2018-11-05 stsp *path_packfile = malloc(size);
170 2090a03d 2018-09-09 stsp if (*path_packfile == NULL)
171 638f9024 2019-05-13 stsp return got_error_from_errno("malloc");
172 2090a03d 2018-09-09 stsp
173 2090a03d 2018-09-09 stsp /* Copy up to and excluding ".idx". */
174 2090a03d 2018-09-09 stsp if (strlcpy(*path_packfile, packidx->path_packidx,
175 2090a03d 2018-09-09 stsp size - strlen(GOT_PACKIDX_SUFFIX) - 1) >= size)
176 2090a03d 2018-09-09 stsp return got_error(GOT_ERR_NO_SPACE);
177 2090a03d 2018-09-09 stsp
178 2090a03d 2018-09-09 stsp if (strlcat(*path_packfile, GOT_PACKFILE_SUFFIX, size) >= size)
179 2090a03d 2018-09-09 stsp return got_error(GOT_ERR_NO_SPACE);
180 2090a03d 2018-09-09 stsp
181 2090a03d 2018-09-09 stsp return NULL;
182 2090a03d 2018-09-09 stsp }
183 2090a03d 2018-09-09 stsp
184 a158c901 2018-12-23 stsp static void
185 a158c901 2018-12-23 stsp exec_privsep_child(int imsg_fds[2], const char *path, const char *repo_path)
186 a158c901 2018-12-23 stsp {
187 3a6ce05a 2019-02-11 stsp if (close(imsg_fds[0]) != 0) {
188 48b8b0eb 2019-05-11 jcs fprintf(stderr, "%s: %s\n", getprogname(), strerror(errno));
189 3a6ce05a 2019-02-11 stsp _exit(1);
190 3a6ce05a 2019-02-11 stsp }
191 a158c901 2018-12-23 stsp
192 a158c901 2018-12-23 stsp if (dup2(imsg_fds[1], GOT_IMSG_FD_CHILD) == -1) {
193 48b8b0eb 2019-05-11 jcs fprintf(stderr, "%s: %s\n", getprogname(), strerror(errno));
194 a158c901 2018-12-23 stsp _exit(1);
195 a158c901 2018-12-23 stsp }
196 a158c901 2018-12-23 stsp if (closefrom(GOT_IMSG_FD_CHILD + 1) == -1) {
197 48b8b0eb 2019-05-11 jcs fprintf(stderr, "%s: %s\n", getprogname(), strerror(errno));
198 a158c901 2018-12-23 stsp _exit(1);
199 a158c901 2018-12-23 stsp }
200 a158c901 2018-12-23 stsp
201 a158c901 2018-12-23 stsp if (execl(path, path, repo_path, (char *)NULL) == -1) {
202 a158c901 2018-12-23 stsp fprintf(stderr, "%s: %s: %s\n", getprogname(), path,
203 a158c901 2018-12-23 stsp strerror(errno));
204 a158c901 2018-12-23 stsp _exit(1);
205 a158c901 2018-12-23 stsp }
206 a158c901 2018-12-23 stsp }
207 a158c901 2018-12-23 stsp
208 2090a03d 2018-09-09 stsp static const struct got_error *
209 a158c901 2018-12-23 stsp request_packed_object(struct got_object **obj, struct got_pack *pack, int idx,
210 a158c901 2018-12-23 stsp struct got_object_id *id)
211 a158c901 2018-12-23 stsp {
212 a158c901 2018-12-23 stsp const struct got_error *err = NULL;
213 a158c901 2018-12-23 stsp struct imsgbuf *ibuf = pack->privsep_child->ibuf;
214 a158c901 2018-12-23 stsp
215 a158c901 2018-12-23 stsp err = got_privsep_send_packed_obj_req(ibuf, idx, id);
216 a158c901 2018-12-23 stsp if (err)
217 a158c901 2018-12-23 stsp return err;
218 a158c901 2018-12-23 stsp
219 a158c901 2018-12-23 stsp err = got_privsep_recv_obj(obj, ibuf);
220 a158c901 2018-12-23 stsp if (err)
221 a158c901 2018-12-23 stsp return err;
222 a158c901 2018-12-23 stsp
223 a158c901 2018-12-23 stsp (*obj)->path_packfile = strdup(pack->path_packfile);
224 a158c901 2018-12-23 stsp if ((*obj)->path_packfile == NULL) {
225 638f9024 2019-05-13 stsp err = got_error_from_errno("strdup");
226 a158c901 2018-12-23 stsp return err;
227 a158c901 2018-12-23 stsp }
228 a158c901 2018-12-23 stsp memcpy(&(*obj)->id, id, sizeof((*obj)->id));
229 a158c901 2018-12-23 stsp
230 a158c901 2018-12-23 stsp return NULL;
231 b48e2ddb 2019-05-22 stsp }
232 b48e2ddb 2019-05-22 stsp
233 da506691 2019-05-22 stsp static void
234 b48e2ddb 2019-05-22 stsp set_max_datasize(void)
235 b48e2ddb 2019-05-22 stsp {
236 b48e2ddb 2019-05-22 stsp struct rlimit rl;
237 b48e2ddb 2019-05-22 stsp
238 b48e2ddb 2019-05-22 stsp if (getrlimit(RLIMIT_DATA, &rl) != 0)
239 b48e2ddb 2019-05-22 stsp return;
240 b48e2ddb 2019-05-22 stsp
241 b48e2ddb 2019-05-22 stsp rl.rlim_cur = rl.rlim_max;
242 b48e2ddb 2019-05-22 stsp setrlimit(RLIMIT_DATA, &rl);
243 a158c901 2018-12-23 stsp }
244 a158c901 2018-12-23 stsp
245 a158c901 2018-12-23 stsp static const struct got_error *
246 711fb6e8 2018-12-23 stsp start_pack_privsep_child(struct got_pack *pack, struct got_packidx *packidx)
247 a158c901 2018-12-23 stsp {
248 a158c901 2018-12-23 stsp const struct got_error *err = NULL;
249 a158c901 2018-12-23 stsp int imsg_fds[2];
250 a158c901 2018-12-23 stsp pid_t pid;
251 a158c901 2018-12-23 stsp struct imsgbuf *ibuf;
252 a158c901 2018-12-23 stsp
253 a158c901 2018-12-23 stsp ibuf = calloc(1, sizeof(*ibuf));
254 a158c901 2018-12-23 stsp if (ibuf == NULL)
255 638f9024 2019-05-13 stsp return got_error_from_errno("calloc");
256 a158c901 2018-12-23 stsp
257 a158c901 2018-12-23 stsp pack->privsep_child = calloc(1, sizeof(*pack->privsep_child));
258 a158c901 2018-12-23 stsp if (pack->privsep_child == NULL) {
259 638f9024 2019-05-13 stsp err = got_error_from_errno("calloc");
260 a158c901 2018-12-23 stsp free(ibuf);
261 a158c901 2018-12-23 stsp return err;
262 a158c901 2018-12-23 stsp }
263 a158c901 2018-12-23 stsp
264 a158c901 2018-12-23 stsp if (socketpair(AF_UNIX, SOCK_STREAM, PF_UNSPEC, imsg_fds) == -1) {
265 638f9024 2019-05-13 stsp err = got_error_from_errno("socketpair");
266 a158c901 2018-12-23 stsp goto done;
267 a158c901 2018-12-23 stsp }
268 a158c901 2018-12-23 stsp
269 a158c901 2018-12-23 stsp pid = fork();
270 a158c901 2018-12-23 stsp if (pid == -1) {
271 638f9024 2019-05-13 stsp err = got_error_from_errno("fork");
272 a158c901 2018-12-23 stsp goto done;
273 a158c901 2018-12-23 stsp } else if (pid == 0) {
274 b48e2ddb 2019-05-22 stsp set_max_datasize();
275 a158c901 2018-12-23 stsp exec_privsep_child(imsg_fds, GOT_PATH_PROG_READ_PACK,
276 a158c901 2018-12-23 stsp pack->path_packfile);
277 a158c901 2018-12-23 stsp /* not reached */
278 a158c901 2018-12-23 stsp }
279 a158c901 2018-12-23 stsp
280 3a6ce05a 2019-02-11 stsp if (close(imsg_fds[1]) != 0)
281 638f9024 2019-05-13 stsp return got_error_from_errno("close");
282 a158c901 2018-12-23 stsp pack->privsep_child->imsg_fd = imsg_fds[0];
283 a158c901 2018-12-23 stsp pack->privsep_child->pid = pid;
284 a158c901 2018-12-23 stsp imsg_init(ibuf, imsg_fds[0]);
285 a158c901 2018-12-23 stsp pack->privsep_child->ibuf = ibuf;
286 a158c901 2018-12-23 stsp
287 a158c901 2018-12-23 stsp err = got_privsep_init_pack_child(ibuf, pack, packidx);
288 a158c901 2018-12-23 stsp if (err) {
289 a158c901 2018-12-23 stsp const struct got_error *child_err;
290 a158c901 2018-12-23 stsp err = got_privsep_send_stop(pack->privsep_child->imsg_fd);
291 a158c901 2018-12-23 stsp child_err = got_privsep_wait_for_child(
292 a158c901 2018-12-23 stsp pack->privsep_child->pid);
293 a158c901 2018-12-23 stsp if (child_err && err == NULL)
294 a158c901 2018-12-23 stsp err = child_err;
295 a158c901 2018-12-23 stsp }
296 a158c901 2018-12-23 stsp done:
297 a158c901 2018-12-23 stsp if (err) {
298 a158c901 2018-12-23 stsp free(ibuf);
299 a158c901 2018-12-23 stsp free(pack->privsep_child);
300 a158c901 2018-12-23 stsp pack->privsep_child = NULL;
301 711fb6e8 2018-12-23 stsp }
302 a158c901 2018-12-23 stsp return err;
303 a158c901 2018-12-23 stsp }
304 a158c901 2018-12-23 stsp
305 711fb6e8 2018-12-23 stsp static const struct got_error *
306 711fb6e8 2018-12-23 stsp read_packed_object_privsep(struct got_object **obj,
307 711fb6e8 2018-12-23 stsp struct got_repository *repo, struct got_pack *pack,
308 711fb6e8 2018-12-23 stsp struct got_packidx *packidx, int idx, struct got_object_id *id)
309 711fb6e8 2018-12-23 stsp {
310 711fb6e8 2018-12-23 stsp const struct got_error *err = NULL;
311 a158c901 2018-12-23 stsp
312 711fb6e8 2018-12-23 stsp if (pack->privsep_child)
313 711fb6e8 2018-12-23 stsp return request_packed_object(obj, pack, idx, id);
314 711fb6e8 2018-12-23 stsp
315 711fb6e8 2018-12-23 stsp err = start_pack_privsep_child(pack, packidx);
316 711fb6e8 2018-12-23 stsp if (err)
317 711fb6e8 2018-12-23 stsp return err;
318 711fb6e8 2018-12-23 stsp
319 711fb6e8 2018-12-23 stsp return request_packed_object(obj, pack, idx, id);
320 711fb6e8 2018-12-23 stsp }
321 711fb6e8 2018-12-23 stsp
322 711fb6e8 2018-12-23 stsp
323 a158c901 2018-12-23 stsp static const struct got_error *
324 2090a03d 2018-09-09 stsp open_packed_object(struct got_object **obj, struct got_object_id *id,
325 2090a03d 2018-09-09 stsp struct got_repository *repo)
326 2090a03d 2018-09-09 stsp {
327 2090a03d 2018-09-09 stsp const struct got_error *err = NULL;
328 2090a03d 2018-09-09 stsp struct got_pack *pack = NULL;
329 2090a03d 2018-09-09 stsp struct got_packidx *packidx = NULL;
330 2090a03d 2018-09-09 stsp int idx;
331 2090a03d 2018-09-09 stsp char *path_packfile;
332 2090a03d 2018-09-09 stsp
333 2090a03d 2018-09-09 stsp err = got_repo_search_packidx(&packidx, &idx, repo, id);
334 2090a03d 2018-09-09 stsp if (err)
335 2090a03d 2018-09-09 stsp return err;
336 2090a03d 2018-09-09 stsp
337 2090a03d 2018-09-09 stsp err = get_packfile_path(&path_packfile, packidx);
338 2090a03d 2018-09-09 stsp if (err)
339 2090a03d 2018-09-09 stsp return err;
340 2090a03d 2018-09-09 stsp
341 2090a03d 2018-09-09 stsp pack = got_repo_get_cached_pack(repo, path_packfile);
342 2090a03d 2018-09-09 stsp if (pack == NULL) {
343 2090a03d 2018-09-09 stsp err = got_repo_cache_pack(&pack, repo, path_packfile, packidx);
344 2090a03d 2018-09-09 stsp if (err)
345 2090a03d 2018-09-09 stsp goto done;
346 2090a03d 2018-09-09 stsp }
347 2090a03d 2018-09-09 stsp
348 a158c901 2018-12-23 stsp err = read_packed_object_privsep(obj, repo, pack, packidx, idx, id);
349 2090a03d 2018-09-09 stsp if (err)
350 2090a03d 2018-09-09 stsp goto done;
351 2090a03d 2018-09-09 stsp
352 2090a03d 2018-09-09 stsp err = got_repo_cache_pack(NULL, repo, (*obj)->path_packfile, packidx);
353 2090a03d 2018-09-09 stsp done:
354 2090a03d 2018-09-09 stsp free(path_packfile);
355 4558fcd4 2018-01-14 stsp return err;
356 9f2369b0 2018-12-24 stsp }
357 9f2369b0 2018-12-24 stsp
358 9f2369b0 2018-12-24 stsp static const struct got_error *
359 9f2369b0 2018-12-24 stsp request_object(struct got_object **obj, struct got_repository *repo, int fd)
360 9f2369b0 2018-12-24 stsp {
361 9f2369b0 2018-12-24 stsp const struct got_error *err = NULL;
362 9f2369b0 2018-12-24 stsp struct imsgbuf *ibuf;
363 9f2369b0 2018-12-24 stsp
364 9f2369b0 2018-12-24 stsp ibuf = repo->privsep_children[GOT_REPO_PRIVSEP_CHILD_OBJECT].ibuf;
365 9f2369b0 2018-12-24 stsp
366 aea5f015 2018-12-24 stsp err = got_privsep_send_obj_req(ibuf, fd);
367 9f2369b0 2018-12-24 stsp if (err)
368 9f2369b0 2018-12-24 stsp return err;
369 9f2369b0 2018-12-24 stsp
370 9f2369b0 2018-12-24 stsp return got_privsep_recv_obj(obj, ibuf);
371 9f2369b0 2018-12-24 stsp }
372 9f2369b0 2018-12-24 stsp
373 9f2369b0 2018-12-24 stsp static const struct got_error *
374 9f2369b0 2018-12-24 stsp read_object_header_privsep(struct got_object **obj, struct got_repository *repo,
375 9f2369b0 2018-12-24 stsp int obj_fd)
376 9f2369b0 2018-12-24 stsp {
377 9f2369b0 2018-12-24 stsp int imsg_fds[2];
378 9f2369b0 2018-12-24 stsp pid_t pid;
379 9f2369b0 2018-12-24 stsp struct imsgbuf *ibuf;
380 9f2369b0 2018-12-24 stsp
381 9f2369b0 2018-12-24 stsp if (repo->privsep_children[GOT_REPO_PRIVSEP_CHILD_OBJECT].imsg_fd != -1)
382 9f2369b0 2018-12-24 stsp return request_object(obj, repo, obj_fd);
383 9f2369b0 2018-12-24 stsp
384 9f2369b0 2018-12-24 stsp ibuf = calloc(1, sizeof(*ibuf));
385 9f2369b0 2018-12-24 stsp if (ibuf == NULL)
386 638f9024 2019-05-13 stsp return got_error_from_errno("calloc");
387 9f2369b0 2018-12-24 stsp
388 9f2369b0 2018-12-24 stsp if (socketpair(AF_UNIX, SOCK_STREAM, PF_UNSPEC, imsg_fds) == -1)
389 638f9024 2019-05-13 stsp return got_error_from_errno("socketpair");
390 9f2369b0 2018-12-24 stsp
391 9f2369b0 2018-12-24 stsp pid = fork();
392 9f2369b0 2018-12-24 stsp if (pid == -1)
393 638f9024 2019-05-13 stsp return got_error_from_errno("fork");
394 9f2369b0 2018-12-24 stsp else if (pid == 0) {
395 9f2369b0 2018-12-24 stsp exec_privsep_child(imsg_fds, GOT_PATH_PROG_READ_OBJECT,
396 9f2369b0 2018-12-24 stsp repo->path);
397 9f2369b0 2018-12-24 stsp /* not reached */
398 9f2369b0 2018-12-24 stsp }
399 9f2369b0 2018-12-24 stsp
400 3a6ce05a 2019-02-11 stsp if (close(imsg_fds[1]) != 0)
401 638f9024 2019-05-13 stsp return got_error_from_errno("close");
402 9f2369b0 2018-12-24 stsp repo->privsep_children[GOT_REPO_PRIVSEP_CHILD_OBJECT].imsg_fd =
403 9f2369b0 2018-12-24 stsp imsg_fds[0];
404 9f2369b0 2018-12-24 stsp repo->privsep_children[GOT_REPO_PRIVSEP_CHILD_OBJECT].pid = pid;
405 9f2369b0 2018-12-24 stsp imsg_init(ibuf, imsg_fds[0]);
406 9f2369b0 2018-12-24 stsp repo->privsep_children[GOT_REPO_PRIVSEP_CHILD_OBJECT].ibuf = ibuf;
407 9f2369b0 2018-12-24 stsp
408 9f2369b0 2018-12-24 stsp return request_object(obj, repo, obj_fd);
409 4558fcd4 2018-01-14 stsp }
410 a1fd68d8 2018-01-12 stsp
411 9f2369b0 2018-12-24 stsp
412 4558fcd4 2018-01-14 stsp const struct got_error *
413 4558fcd4 2018-01-14 stsp got_object_open(struct got_object **obj, struct got_repository *repo,
414 4558fcd4 2018-01-14 stsp struct got_object_id *id)
415 4558fcd4 2018-01-14 stsp {
416 6c00b545 2018-01-17 stsp const struct got_error *err = NULL;
417 6c00b545 2018-01-17 stsp char *path;
418 2178c42e 2018-04-22 stsp int fd;
419 7bb0daa1 2018-06-21 stsp
420 7bb0daa1 2018-06-21 stsp *obj = got_repo_get_cached_object(repo, id);
421 7bb0daa1 2018-06-21 stsp if (*obj != NULL) {
422 7bb0daa1 2018-06-21 stsp (*obj)->refcnt++;
423 7bb0daa1 2018-06-21 stsp return NULL;
424 7bb0daa1 2018-06-21 stsp }
425 4558fcd4 2018-01-14 stsp
426 e82b1d81 2019-07-27 stsp err = open_packed_object(obj, id, repo);
427 e82b1d81 2019-07-27 stsp if (err && err->code != GOT_ERR_NO_OBJ)
428 e82b1d81 2019-07-27 stsp return err;
429 e82b1d81 2019-07-27 stsp if (*obj) {
430 e82b1d81 2019-07-27 stsp (*obj)->refcnt++;
431 e82b1d81 2019-07-27 stsp return got_repo_cache_object(repo, id, *obj);
432 e82b1d81 2019-07-27 stsp }
433 e82b1d81 2019-07-27 stsp
434 90bdb554 2019-04-11 stsp err = got_object_get_path(&path, id, repo);
435 4558fcd4 2018-01-14 stsp if (err)
436 4558fcd4 2018-01-14 stsp return err;
437 4558fcd4 2018-01-14 stsp
438 a5b57ccf 2019-04-11 stsp fd = open(path, O_RDONLY | O_NOFOLLOW);
439 2178c42e 2018-04-22 stsp if (fd == -1) {
440 e82b1d81 2019-07-27 stsp if (errno == ENOENT)
441 e82b1d81 2019-07-27 stsp err = got_error_no_obj(id);
442 e82b1d81 2019-07-27 stsp else
443 638f9024 2019-05-13 stsp err = got_error_from_errno2("open", path);
444 e82b1d81 2019-07-27 stsp goto done;
445 6c00b545 2018-01-17 stsp } else {
446 9f2369b0 2018-12-24 stsp err = read_object_header_privsep(obj, repo, fd);
447 6c00b545 2018-01-17 stsp if (err)
448 6c00b545 2018-01-17 stsp goto done;
449 ab9a70b2 2017-11-06 stsp memcpy((*obj)->id.sha1, id->sha1, SHA1_DIGEST_LENGTH);
450 6c00b545 2018-01-17 stsp }
451 7bb0daa1 2018-06-21 stsp
452 59790a32 2018-09-15 stsp (*obj)->refcnt++;
453 59790a32 2018-09-15 stsp err = got_repo_cache_object(repo, id, *obj);
454 6c00b545 2018-01-17 stsp done:
455 6c00b545 2018-01-17 stsp free(path);
456 ab9a70b2 2017-11-06 stsp return err;
457 6c00b545 2018-01-17 stsp
458 ab9a70b2 2017-11-06 stsp }
459 ab9a70b2 2017-11-06 stsp
460 6dfa2fd3 2018-02-12 stsp const struct got_error *
461 6dfa2fd3 2018-02-12 stsp got_object_open_by_id_str(struct got_object **obj, struct got_repository *repo,
462 6dfa2fd3 2018-02-12 stsp const char *id_str)
463 6dfa2fd3 2018-02-12 stsp {
464 6dfa2fd3 2018-02-12 stsp struct got_object_id id;
465 6dfa2fd3 2018-02-12 stsp
466 6dfa2fd3 2018-02-12 stsp if (!got_parse_sha1_digest(id.sha1, id_str))
467 6dfa2fd3 2018-02-12 stsp return got_error(GOT_ERR_BAD_OBJ_ID_STR);
468 6dfa2fd3 2018-02-12 stsp
469 6dfa2fd3 2018-02-12 stsp return got_object_open(obj, repo, &id);
470 15a94983 2018-12-23 stsp }
471 15a94983 2018-12-23 stsp
472 15a94983 2018-12-23 stsp const struct got_error *
473 15a94983 2018-12-23 stsp got_object_resolve_id_str(struct got_object_id **id,
474 15a94983 2018-12-23 stsp struct got_repository *repo, const char *id_str)
475 15a94983 2018-12-23 stsp {
476 15a94983 2018-12-23 stsp const struct got_error *err = NULL;
477 15a94983 2018-12-23 stsp struct got_object *obj;
478 15a94983 2018-12-23 stsp
479 15a94983 2018-12-23 stsp err = got_object_open_by_id_str(&obj, repo, id_str);
480 15a94983 2018-12-23 stsp if (err)
481 15a94983 2018-12-23 stsp return err;
482 15a94983 2018-12-23 stsp
483 15a94983 2018-12-23 stsp *id = got_object_id_dup(got_object_get_id(obj));
484 15a94983 2018-12-23 stsp got_object_close(obj);
485 15a94983 2018-12-23 stsp if (*id == NULL)
486 638f9024 2019-05-13 stsp return got_error_from_errno("got_object_id_dup");
487 15a94983 2018-12-23 stsp
488 15a94983 2018-12-23 stsp return NULL;
489 434025f3 2018-09-16 stsp }
490 434025f3 2018-09-16 stsp
491 434025f3 2018-09-16 stsp static const struct got_error *
492 a158c901 2018-12-23 stsp request_packed_commit(struct got_commit_object **commit, struct got_pack *pack,
493 a158c901 2018-12-23 stsp int pack_idx, struct got_object_id *id)
494 a158c901 2018-12-23 stsp {
495 a158c901 2018-12-23 stsp const struct got_error *err = NULL;
496 a158c901 2018-12-23 stsp
497 a158c901 2018-12-23 stsp err = got_privsep_send_commit_req(pack->privsep_child->ibuf, -1, id,
498 a158c901 2018-12-23 stsp pack_idx);
499 a158c901 2018-12-23 stsp if (err)
500 a158c901 2018-12-23 stsp return err;
501 a158c901 2018-12-23 stsp
502 a158c901 2018-12-23 stsp return got_privsep_recv_commit(commit, pack->privsep_child->ibuf);
503 a158c901 2018-12-23 stsp }
504 a158c901 2018-12-23 stsp
505 a158c901 2018-12-23 stsp static const struct got_error *
506 a158c901 2018-12-23 stsp read_packed_commit_privsep(struct got_commit_object **commit,
507 a158c901 2018-12-23 stsp struct got_pack *pack, struct got_packidx *packidx, int idx,
508 a158c901 2018-12-23 stsp struct got_object_id *id)
509 a158c901 2018-12-23 stsp {
510 a158c901 2018-12-23 stsp const struct got_error *err = NULL;
511 a158c901 2018-12-23 stsp
512 a158c901 2018-12-23 stsp if (pack->privsep_child)
513 a158c901 2018-12-23 stsp return request_packed_commit(commit, pack, idx, id);
514 a158c901 2018-12-23 stsp
515 711fb6e8 2018-12-23 stsp err = start_pack_privsep_child(pack, packidx);
516 711fb6e8 2018-12-23 stsp if (err)
517 a158c901 2018-12-23 stsp return err;
518 a158c901 2018-12-23 stsp
519 711fb6e8 2018-12-23 stsp return request_packed_commit(commit, pack, idx, id);
520 9f2369b0 2018-12-24 stsp }
521 9f2369b0 2018-12-24 stsp
522 9f2369b0 2018-12-24 stsp static const struct got_error *
523 9f2369b0 2018-12-24 stsp request_commit(struct got_commit_object **commit, struct got_repository *repo,
524 9f2369b0 2018-12-24 stsp int fd)
525 9f2369b0 2018-12-24 stsp {
526 9f2369b0 2018-12-24 stsp const struct got_error *err = NULL;
527 9f2369b0 2018-12-24 stsp struct imsgbuf *ibuf;
528 9f2369b0 2018-12-24 stsp
529 9f2369b0 2018-12-24 stsp ibuf = repo->privsep_children[GOT_REPO_PRIVSEP_CHILD_COMMIT].ibuf;
530 9f2369b0 2018-12-24 stsp
531 9f2369b0 2018-12-24 stsp err = got_privsep_send_commit_req(ibuf, fd, NULL, -1);
532 9f2369b0 2018-12-24 stsp if (err)
533 9f2369b0 2018-12-24 stsp return err;
534 9f2369b0 2018-12-24 stsp
535 9f2369b0 2018-12-24 stsp return got_privsep_recv_commit(commit, ibuf);
536 9f2369b0 2018-12-24 stsp }
537 9f2369b0 2018-12-24 stsp
538 9f2369b0 2018-12-24 stsp static const struct got_error *
539 9f2369b0 2018-12-24 stsp read_commit_privsep(struct got_commit_object **commit, int obj_fd,
540 9f2369b0 2018-12-24 stsp struct got_repository *repo)
541 9f2369b0 2018-12-24 stsp {
542 9f2369b0 2018-12-24 stsp int imsg_fds[2];
543 9f2369b0 2018-12-24 stsp pid_t pid;
544 9f2369b0 2018-12-24 stsp struct imsgbuf *ibuf;
545 9f2369b0 2018-12-24 stsp
546 9f2369b0 2018-12-24 stsp if (repo->privsep_children[GOT_REPO_PRIVSEP_CHILD_COMMIT].imsg_fd != -1)
547 9f2369b0 2018-12-24 stsp return request_commit(commit, repo, obj_fd);
548 9f2369b0 2018-12-24 stsp
549 9f2369b0 2018-12-24 stsp ibuf = calloc(1, sizeof(*ibuf));
550 9f2369b0 2018-12-24 stsp if (ibuf == NULL)
551 638f9024 2019-05-13 stsp return got_error_from_errno("calloc");
552 9f2369b0 2018-12-24 stsp
553 9f2369b0 2018-12-24 stsp if (socketpair(AF_UNIX, SOCK_STREAM, PF_UNSPEC, imsg_fds) == -1)
554 638f9024 2019-05-13 stsp return got_error_from_errno("socketpair");
555 9f2369b0 2018-12-24 stsp
556 9f2369b0 2018-12-24 stsp pid = fork();
557 9f2369b0 2018-12-24 stsp if (pid == -1)
558 638f9024 2019-05-13 stsp return got_error_from_errno("fork");
559 9f2369b0 2018-12-24 stsp else if (pid == 0) {
560 9f2369b0 2018-12-24 stsp exec_privsep_child(imsg_fds, GOT_PATH_PROG_READ_COMMIT,
561 9f2369b0 2018-12-24 stsp repo->path);
562 9f2369b0 2018-12-24 stsp /* not reached */
563 9f2369b0 2018-12-24 stsp }
564 9f2369b0 2018-12-24 stsp
565 3a6ce05a 2019-02-11 stsp if (close(imsg_fds[1]) != 0)
566 638f9024 2019-05-13 stsp return got_error_from_errno("close");
567 9f2369b0 2018-12-24 stsp repo->privsep_children[GOT_REPO_PRIVSEP_CHILD_COMMIT].imsg_fd =
568 9f2369b0 2018-12-24 stsp imsg_fds[0];
569 9f2369b0 2018-12-24 stsp repo->privsep_children[GOT_REPO_PRIVSEP_CHILD_COMMIT].pid = pid;
570 9f2369b0 2018-12-24 stsp imsg_init(ibuf, imsg_fds[0]);
571 9f2369b0 2018-12-24 stsp repo->privsep_children[GOT_REPO_PRIVSEP_CHILD_COMMIT].ibuf = ibuf;
572 9f2369b0 2018-12-24 stsp
573 9f2369b0 2018-12-24 stsp return request_commit(commit, repo, obj_fd);
574 a158c901 2018-12-23 stsp }
575 a158c901 2018-12-23 stsp
576 9f2369b0 2018-12-24 stsp
577 a158c901 2018-12-23 stsp static const struct got_error *
578 434025f3 2018-09-16 stsp open_commit(struct got_commit_object **commit,
579 1785f84a 2018-12-23 stsp struct got_repository *repo, struct got_object_id *id, int check_cache)
580 434025f3 2018-09-16 stsp {
581 434025f3 2018-09-16 stsp const struct got_error *err = NULL;
582 1785f84a 2018-12-23 stsp struct got_packidx *packidx = NULL;
583 e82b1d81 2019-07-27 stsp int idx;
584 8d2c5ea3 2019-08-13 stsp char *path_packfile = NULL;
585 434025f3 2018-09-16 stsp
586 434025f3 2018-09-16 stsp if (check_cache) {
587 1785f84a 2018-12-23 stsp *commit = got_repo_get_cached_commit(repo, id);
588 434025f3 2018-09-16 stsp if (*commit != NULL) {
589 434025f3 2018-09-16 stsp (*commit)->refcnt++;
590 434025f3 2018-09-16 stsp return NULL;
591 434025f3 2018-09-16 stsp }
592 434025f3 2018-09-16 stsp } else
593 434025f3 2018-09-16 stsp *commit = NULL;
594 434025f3 2018-09-16 stsp
595 e82b1d81 2019-07-27 stsp err = got_repo_search_packidx(&packidx, &idx, repo, id);
596 e82b1d81 2019-07-27 stsp if (err == NULL) {
597 1785f84a 2018-12-23 stsp struct got_pack *pack = NULL;
598 34f480ff 2019-07-27 stsp
599 1785f84a 2018-12-23 stsp err = get_packfile_path(&path_packfile, packidx);
600 1785f84a 2018-12-23 stsp if (err)
601 1785f84a 2018-12-23 stsp return err;
602 1785f84a 2018-12-23 stsp
603 1785f84a 2018-12-23 stsp pack = got_repo_get_cached_pack(repo, path_packfile);
604 434025f3 2018-09-16 stsp if (pack == NULL) {
605 1785f84a 2018-12-23 stsp err = got_repo_cache_pack(&pack, repo, path_packfile,
606 1785f84a 2018-12-23 stsp packidx);
607 434025f3 2018-09-16 stsp if (err)
608 8d2c5ea3 2019-08-13 stsp goto done;
609 434025f3 2018-09-16 stsp }
610 a158c901 2018-12-23 stsp err = read_packed_commit_privsep(commit, pack,
611 1785f84a 2018-12-23 stsp packidx, idx, id);
612 e82b1d81 2019-07-27 stsp } else if (err->code == GOT_ERR_NO_OBJ) {
613 e82b1d81 2019-07-27 stsp int fd;
614 e82b1d81 2019-07-27 stsp
615 e82b1d81 2019-07-27 stsp err = open_loose_object(&fd, id, repo);
616 e82b1d81 2019-07-27 stsp if (err)
617 e82b1d81 2019-07-27 stsp return err;
618 9f2369b0 2018-12-24 stsp err = read_commit_privsep(commit, fd, repo);
619 e82b1d81 2019-07-27 stsp }
620 434025f3 2018-09-16 stsp
621 434025f3 2018-09-16 stsp if (err == NULL) {
622 434025f3 2018-09-16 stsp (*commit)->refcnt++;
623 1785f84a 2018-12-23 stsp err = got_repo_cache_commit(repo, id, *commit);
624 e32baab7 2018-11-05 stsp }
625 8d2c5ea3 2019-08-13 stsp done:
626 8d2c5ea3 2019-08-13 stsp free(path_packfile);
627 e32baab7 2018-11-05 stsp return err;
628 e32baab7 2018-11-05 stsp }
629 e32baab7 2018-11-05 stsp
630 e32baab7 2018-11-05 stsp const struct got_error *
631 e32baab7 2018-11-05 stsp got_object_open_as_commit(struct got_commit_object **commit,
632 e32baab7 2018-11-05 stsp struct got_repository *repo, struct got_object_id *id)
633 e32baab7 2018-11-05 stsp {
634 e32baab7 2018-11-05 stsp *commit = got_repo_get_cached_commit(repo, id);
635 e32baab7 2018-11-05 stsp if (*commit != NULL) {
636 e32baab7 2018-11-05 stsp (*commit)->refcnt++;
637 e32baab7 2018-11-05 stsp return NULL;
638 e32baab7 2018-11-05 stsp }
639 e32baab7 2018-11-05 stsp
640 1785f84a 2018-12-23 stsp return open_commit(commit, repo, id, 0);
641 7762fe12 2018-11-05 stsp }
642 7762fe12 2018-11-05 stsp
643 e32baab7 2018-11-05 stsp const struct got_error *
644 e32baab7 2018-11-05 stsp got_object_commit_open(struct got_commit_object **commit,
645 e32baab7 2018-11-05 stsp struct got_repository *repo, struct got_object *obj)
646 e32baab7 2018-11-05 stsp {
647 1785f84a 2018-12-23 stsp return open_commit(commit, repo, got_object_get_id(obj), 1);
648 434025f3 2018-09-16 stsp }
649 434025f3 2018-09-16 stsp
650 434025f3 2018-09-16 stsp const struct got_error *
651 dbc6a6b6 2018-07-12 stsp got_object_qid_alloc(struct got_object_qid **qid, struct got_object_id *id)
652 dbc6a6b6 2018-07-12 stsp {
653 dbc6a6b6 2018-07-12 stsp const struct got_error *err = NULL;
654 dbc6a6b6 2018-07-12 stsp
655 dbc6a6b6 2018-07-12 stsp *qid = calloc(1, sizeof(**qid));
656 dbc6a6b6 2018-07-12 stsp if (*qid == NULL)
657 638f9024 2019-05-13 stsp return got_error_from_errno("calloc");
658 dbc6a6b6 2018-07-12 stsp
659 dbc6a6b6 2018-07-12 stsp (*qid)->id = got_object_id_dup(id);
660 dbc6a6b6 2018-07-12 stsp if ((*qid)->id == NULL) {
661 638f9024 2019-05-13 stsp err = got_error_from_errno("got_object_id_dup");
662 fa2f6902 2018-07-23 stsp got_object_qid_free(*qid);
663 dbc6a6b6 2018-07-12 stsp *qid = NULL;
664 dbc6a6b6 2018-07-12 stsp return err;
665 dbc6a6b6 2018-07-12 stsp }
666 dbc6a6b6 2018-07-12 stsp
667 dbc6a6b6 2018-07-12 stsp return NULL;
668 a158c901 2018-12-23 stsp }
669 a158c901 2018-12-23 stsp
670 a158c901 2018-12-23 stsp static const struct got_error *
671 13c729f7 2018-12-24 stsp request_packed_tree(struct got_tree_object **tree, struct got_pack *pack,
672 13c729f7 2018-12-24 stsp int pack_idx, struct got_object_id *id)
673 a158c901 2018-12-23 stsp {
674 a158c901 2018-12-23 stsp const struct got_error *err = NULL;
675 a158c901 2018-12-23 stsp
676 13c729f7 2018-12-24 stsp err = got_privsep_send_tree_req(pack->privsep_child->ibuf, -1, id,
677 13c729f7 2018-12-24 stsp pack_idx);
678 a158c901 2018-12-23 stsp if (err)
679 a158c901 2018-12-23 stsp return err;
680 a158c901 2018-12-23 stsp
681 a158c901 2018-12-23 stsp return got_privsep_recv_tree(tree, pack->privsep_child->ibuf);
682 7e212e3d 2018-09-09 stsp }
683 7e212e3d 2018-09-09 stsp
684 71eb0e7f 2018-09-16 stsp static const struct got_error *
685 13c729f7 2018-12-24 stsp read_packed_tree_privsep(struct got_tree_object **tree,
686 13c729f7 2018-12-24 stsp struct got_pack *pack, struct got_packidx *packidx, int idx,
687 13c729f7 2018-12-24 stsp struct got_object_id *id)
688 13c729f7 2018-12-24 stsp {
689 13c729f7 2018-12-24 stsp const struct got_error *err = NULL;
690 13c729f7 2018-12-24 stsp
691 13c729f7 2018-12-24 stsp if (pack->privsep_child)
692 13c729f7 2018-12-24 stsp return request_packed_tree(tree, pack, idx, id);
693 13c729f7 2018-12-24 stsp
694 13c729f7 2018-12-24 stsp err = start_pack_privsep_child(pack, packidx);
695 13c729f7 2018-12-24 stsp if (err)
696 13c729f7 2018-12-24 stsp return err;
697 13c729f7 2018-12-24 stsp
698 13c729f7 2018-12-24 stsp return request_packed_tree(tree, pack, idx, id);
699 13c729f7 2018-12-24 stsp }
700 13c729f7 2018-12-24 stsp
701 13c729f7 2018-12-24 stsp static const struct got_error *
702 9f2369b0 2018-12-24 stsp request_tree(struct got_tree_object **tree, struct got_repository *repo,
703 9f2369b0 2018-12-24 stsp int fd)
704 9f2369b0 2018-12-24 stsp {
705 9f2369b0 2018-12-24 stsp const struct got_error *err = NULL;
706 9f2369b0 2018-12-24 stsp struct imsgbuf *ibuf;
707 9f2369b0 2018-12-24 stsp
708 9f2369b0 2018-12-24 stsp ibuf = repo->privsep_children[GOT_REPO_PRIVSEP_CHILD_TREE].ibuf;
709 9f2369b0 2018-12-24 stsp
710 9f2369b0 2018-12-24 stsp err = got_privsep_send_tree_req(ibuf, fd, NULL, -1);
711 9f2369b0 2018-12-24 stsp if (err)
712 9f2369b0 2018-12-24 stsp return err;
713 9f2369b0 2018-12-24 stsp
714 9f2369b0 2018-12-24 stsp return got_privsep_recv_tree(tree, ibuf);
715 9f2369b0 2018-12-24 stsp }
716 9f2369b0 2018-12-24 stsp
717 9f2369b0 2018-12-24 stsp const struct got_error *
718 9f2369b0 2018-12-24 stsp read_tree_privsep(struct got_tree_object **tree, int obj_fd,
719 9f2369b0 2018-12-24 stsp struct got_repository *repo)
720 9f2369b0 2018-12-24 stsp {
721 9f2369b0 2018-12-24 stsp int imsg_fds[2];
722 9f2369b0 2018-12-24 stsp pid_t pid;
723 9f2369b0 2018-12-24 stsp struct imsgbuf *ibuf;
724 9f2369b0 2018-12-24 stsp
725 9f2369b0 2018-12-24 stsp if (repo->privsep_children[GOT_REPO_PRIVSEP_CHILD_TREE].imsg_fd != -1)
726 9f2369b0 2018-12-24 stsp return request_tree(tree, repo, obj_fd);
727 9f2369b0 2018-12-24 stsp
728 9f2369b0 2018-12-24 stsp ibuf = calloc(1, sizeof(*ibuf));
729 9f2369b0 2018-12-24 stsp if (ibuf == NULL)
730 638f9024 2019-05-13 stsp return got_error_from_errno("calloc");
731 9f2369b0 2018-12-24 stsp
732 9f2369b0 2018-12-24 stsp if (socketpair(AF_UNIX, SOCK_STREAM, PF_UNSPEC, imsg_fds) == -1)
733 638f9024 2019-05-13 stsp return got_error_from_errno("socketpair");
734 9f2369b0 2018-12-24 stsp
735 9f2369b0 2018-12-24 stsp pid = fork();
736 9f2369b0 2018-12-24 stsp if (pid == -1)
737 638f9024 2019-05-13 stsp return got_error_from_errno("fork");
738 9f2369b0 2018-12-24 stsp else if (pid == 0) {
739 9f2369b0 2018-12-24 stsp exec_privsep_child(imsg_fds, GOT_PATH_PROG_READ_TREE,
740 9f2369b0 2018-12-24 stsp repo->path);
741 9f2369b0 2018-12-24 stsp /* not reached */
742 9f2369b0 2018-12-24 stsp }
743 9f2369b0 2018-12-24 stsp
744 3a6ce05a 2019-02-11 stsp if (close(imsg_fds[1]) != 0)
745 638f9024 2019-05-13 stsp return got_error_from_errno("close");
746 9f2369b0 2018-12-24 stsp repo->privsep_children[GOT_REPO_PRIVSEP_CHILD_TREE].imsg_fd =
747 9f2369b0 2018-12-24 stsp imsg_fds[0];
748 9f2369b0 2018-12-24 stsp repo->privsep_children[GOT_REPO_PRIVSEP_CHILD_TREE].pid = pid;
749 9f2369b0 2018-12-24 stsp imsg_init(ibuf, imsg_fds[0]);
750 9f2369b0 2018-12-24 stsp repo->privsep_children[GOT_REPO_PRIVSEP_CHILD_TREE].ibuf = ibuf;
751 9f2369b0 2018-12-24 stsp
752 9f2369b0 2018-12-24 stsp
753 9f2369b0 2018-12-24 stsp return request_tree(tree, repo, obj_fd);
754 9f2369b0 2018-12-24 stsp }
755 9f2369b0 2018-12-24 stsp
756 9f2369b0 2018-12-24 stsp static const struct got_error *
757 13c729f7 2018-12-24 stsp open_tree(struct got_tree_object **tree, struct got_repository *repo,
758 13c729f7 2018-12-24 stsp struct got_object_id *id, int check_cache)
759 0ffeb3c2 2017-11-26 stsp {
760 0ffeb3c2 2017-11-26 stsp const struct got_error *err = NULL;
761 13c729f7 2018-12-24 stsp struct got_packidx *packidx = NULL;
762 e82b1d81 2019-07-27 stsp int idx;
763 8d2c5ea3 2019-08-13 stsp char *path_packfile = NULL;
764 f6be5c30 2018-06-22 stsp
765 71eb0e7f 2018-09-16 stsp if (check_cache) {
766 13c729f7 2018-12-24 stsp *tree = got_repo_get_cached_tree(repo, id);
767 71eb0e7f 2018-09-16 stsp if (*tree != NULL) {
768 71eb0e7f 2018-09-16 stsp (*tree)->refcnt++;
769 71eb0e7f 2018-09-16 stsp return NULL;
770 71eb0e7f 2018-09-16 stsp }
771 71eb0e7f 2018-09-16 stsp } else
772 71eb0e7f 2018-09-16 stsp *tree = NULL;
773 0ffeb3c2 2017-11-26 stsp
774 e82b1d81 2019-07-27 stsp err = got_repo_search_packidx(&packidx, &idx, repo, id);
775 e82b1d81 2019-07-27 stsp if (err == NULL) {
776 13c729f7 2018-12-24 stsp struct got_pack *pack = NULL;
777 0ffeb3c2 2017-11-26 stsp
778 13c729f7 2018-12-24 stsp err = get_packfile_path(&path_packfile, packidx);
779 13c729f7 2018-12-24 stsp if (err)
780 13c729f7 2018-12-24 stsp return err;
781 13c729f7 2018-12-24 stsp
782 13c729f7 2018-12-24 stsp pack = got_repo_get_cached_pack(repo, path_packfile);
783 e7885405 2018-09-10 stsp if (pack == NULL) {
784 e82b1d81 2019-07-27 stsp err = got_repo_cache_pack(&pack, repo, path_packfile,
785 e82b1d81 2019-07-27 stsp packidx);
786 e7885405 2018-09-10 stsp if (err)
787 8d2c5ea3 2019-08-13 stsp goto done;
788 e7885405 2018-09-10 stsp }
789 13c729f7 2018-12-24 stsp err = read_packed_tree_privsep(tree, pack,
790 13c729f7 2018-12-24 stsp packidx, idx, id);
791 e82b1d81 2019-07-27 stsp } else if (err->code == GOT_ERR_NO_OBJ) {
792 e82b1d81 2019-07-27 stsp int fd;
793 e82b1d81 2019-07-27 stsp
794 e82b1d81 2019-07-27 stsp err = open_loose_object(&fd, id, repo);
795 e82b1d81 2019-07-27 stsp if (err)
796 e82b1d81 2019-07-27 stsp return err;
797 9f2369b0 2018-12-24 stsp err = read_tree_privsep(tree, fd, repo);
798 e82b1d81 2019-07-27 stsp }
799 f6be5c30 2018-06-22 stsp
800 f6be5c30 2018-06-22 stsp if (err == NULL) {
801 f6be5c30 2018-06-22 stsp (*tree)->refcnt++;
802 13c729f7 2018-12-24 stsp err = got_repo_cache_tree(repo, id, *tree);
803 f6be5c30 2018-06-22 stsp }
804 8d2c5ea3 2019-08-13 stsp done:
805 8d2c5ea3 2019-08-13 stsp free(path_packfile);
806 776d4d29 2018-06-17 stsp return err;
807 776d4d29 2018-06-17 stsp }
808 776d4d29 2018-06-17 stsp
809 776d4d29 2018-06-17 stsp const struct got_error *
810 776d4d29 2018-06-17 stsp got_object_open_as_tree(struct got_tree_object **tree,
811 776d4d29 2018-06-17 stsp struct got_repository *repo, struct got_object_id *id)
812 776d4d29 2018-06-17 stsp {
813 e8eb494a 2018-09-16 stsp *tree = got_repo_get_cached_tree(repo, id);
814 e8eb494a 2018-09-16 stsp if (*tree != NULL) {
815 e8eb494a 2018-09-16 stsp (*tree)->refcnt++;
816 e8eb494a 2018-09-16 stsp return NULL;
817 e0ab43e7 2018-03-16 stsp }
818 776d4d29 2018-06-17 stsp
819 13c729f7 2018-12-24 stsp return open_tree(tree, repo, id, 0);
820 57efb1af 2018-04-24 stsp }
821 ff6b18f8 2018-04-24 stsp
822 71eb0e7f 2018-09-16 stsp const struct got_error *
823 71eb0e7f 2018-09-16 stsp got_object_tree_open(struct got_tree_object **tree,
824 71eb0e7f 2018-09-16 stsp struct got_repository *repo, struct got_object *obj)
825 71eb0e7f 2018-09-16 stsp {
826 13c729f7 2018-12-24 stsp return open_tree(tree, repo, got_object_get_id(obj), 1);
827 71eb0e7f 2018-09-16 stsp }
828 71eb0e7f 2018-09-16 stsp
829 883f0469 2018-06-23 stsp const struct got_tree_entries *
830 883f0469 2018-06-23 stsp got_object_tree_get_entries(struct got_tree_object *tree)
831 883f0469 2018-06-23 stsp {
832 883f0469 2018-06-23 stsp return &tree->entries;
833 883f0469 2018-06-23 stsp }
834 3840f4c9 2018-09-12 stsp
835 3840f4c9 2018-09-12 stsp static const struct got_error *
836 ac544f8c 2019-01-13 stsp request_packed_blob(uint8_t **outbuf, size_t *size, size_t *hdrlen, int outfd,
837 ebc55e2d 2018-12-24 stsp struct got_pack *pack, struct got_packidx *packidx, int idx,
838 ebc55e2d 2018-12-24 stsp struct got_object_id *id)
839 3840f4c9 2018-09-12 stsp {
840 3840f4c9 2018-09-12 stsp const struct got_error *err = NULL;
841 3840f4c9 2018-09-12 stsp int outfd_child;
842 3840f4c9 2018-09-12 stsp int basefd, accumfd; /* temporary files for delta application */
843 24140570 2018-09-09 stsp
844 3840f4c9 2018-09-12 stsp basefd = got_opentempfd();
845 3840f4c9 2018-09-12 stsp if (basefd == -1)
846 638f9024 2019-05-13 stsp return got_error_from_errno("got_opentempfd");
847 3840f4c9 2018-09-12 stsp accumfd = got_opentempfd();
848 3840f4c9 2018-09-12 stsp if (accumfd == -1)
849 638f9024 2019-05-13 stsp return got_error_from_errno("got_opentempfd");
850 3840f4c9 2018-09-12 stsp
851 3840f4c9 2018-09-12 stsp outfd_child = dup(outfd);
852 3840f4c9 2018-09-12 stsp if (outfd_child == -1)
853 638f9024 2019-05-13 stsp return got_error_from_errno("dup");
854 3840f4c9 2018-09-12 stsp
855 ebc55e2d 2018-12-24 stsp err = got_privsep_send_blob_req(pack->privsep_child->ibuf, -1, id, idx);
856 3840f4c9 2018-09-12 stsp if (err)
857 3840f4c9 2018-09-12 stsp return err;
858 3840f4c9 2018-09-12 stsp
859 3840f4c9 2018-09-12 stsp err = got_privsep_send_blob_outfd(pack->privsep_child->ibuf,
860 3840f4c9 2018-09-12 stsp outfd_child);
861 3840f4c9 2018-09-12 stsp if (err) {
862 41496140 2019-02-21 stsp close(basefd);
863 41496140 2019-02-21 stsp close(accumfd);
864 3840f4c9 2018-09-12 stsp return err;
865 3840f4c9 2018-09-12 stsp }
866 41496140 2019-02-21 stsp
867 3840f4c9 2018-09-12 stsp err = got_privsep_send_tmpfd(pack->privsep_child->ibuf,
868 3840f4c9 2018-09-12 stsp basefd);
869 3840f4c9 2018-09-12 stsp if (err) {
870 3840f4c9 2018-09-12 stsp close(accumfd);
871 3840f4c9 2018-09-12 stsp return err;
872 3840f4c9 2018-09-12 stsp }
873 3840f4c9 2018-09-12 stsp
874 3840f4c9 2018-09-12 stsp err = got_privsep_send_tmpfd(pack->privsep_child->ibuf,
875 3840f4c9 2018-09-12 stsp accumfd);
876 41496140 2019-02-21 stsp if (err)
877 3840f4c9 2018-09-12 stsp return err;
878 3840f4c9 2018-09-12 stsp
879 ac544f8c 2019-01-13 stsp err = got_privsep_recv_blob(outbuf, size, hdrlen,
880 ebc55e2d 2018-12-24 stsp pack->privsep_child->ibuf);
881 3840f4c9 2018-09-12 stsp if (err)
882 3840f4c9 2018-09-12 stsp return err;
883 3840f4c9 2018-09-12 stsp
884 3840f4c9 2018-09-12 stsp if (lseek(outfd, SEEK_SET, 0) == -1)
885 638f9024 2019-05-13 stsp err = got_error_from_errno("lseek");
886 3840f4c9 2018-09-12 stsp
887 3840f4c9 2018-09-12 stsp return err;
888 3840f4c9 2018-09-12 stsp }
889 3840f4c9 2018-09-12 stsp
890 ebc55e2d 2018-12-24 stsp static const struct got_error *
891 ac544f8c 2019-01-13 stsp read_packed_blob_privsep(uint8_t **outbuf, size_t *size, size_t *hdrlen,
892 ac544f8c 2019-01-13 stsp int outfd, struct got_pack *pack, struct got_packidx *packidx, int idx,
893 ebc55e2d 2018-12-24 stsp struct got_object_id *id)
894 68482ea3 2017-11-27 stsp {
895 68482ea3 2017-11-27 stsp const struct got_error *err = NULL;
896 ebc55e2d 2018-12-24 stsp
897 ebc55e2d 2018-12-24 stsp if (pack->privsep_child == NULL) {
898 ebc55e2d 2018-12-24 stsp err = start_pack_privsep_child(pack, packidx);
899 ebc55e2d 2018-12-24 stsp if (err)
900 ebc55e2d 2018-12-24 stsp return err;
901 ebc55e2d 2018-12-24 stsp }
902 68482ea3 2017-11-27 stsp
903 ac544f8c 2019-01-13 stsp return request_packed_blob(outbuf, size, hdrlen, outfd, pack, packidx,
904 ac544f8c 2019-01-13 stsp idx, id);
905 9f2369b0 2018-12-24 stsp }
906 9f2369b0 2018-12-24 stsp
907 9f2369b0 2018-12-24 stsp static const struct got_error *
908 ac544f8c 2019-01-13 stsp request_blob(uint8_t **outbuf, size_t *size, size_t *hdrlen, int outfd,
909 ac544f8c 2019-01-13 stsp int infd, struct imsgbuf *ibuf)
910 9f2369b0 2018-12-24 stsp {
911 9f2369b0 2018-12-24 stsp const struct got_error *err = NULL;
912 9f2369b0 2018-12-24 stsp int outfd_child;
913 9f2369b0 2018-12-24 stsp
914 9f2369b0 2018-12-24 stsp outfd_child = dup(outfd);
915 9f2369b0 2018-12-24 stsp if (outfd_child == -1)
916 638f9024 2019-05-13 stsp return got_error_from_errno("dup");
917 9f2369b0 2018-12-24 stsp
918 9f2369b0 2018-12-24 stsp err = got_privsep_send_blob_req(ibuf, infd, NULL, -1);
919 9f2369b0 2018-12-24 stsp if (err)
920 9f2369b0 2018-12-24 stsp return err;
921 9f2369b0 2018-12-24 stsp
922 9f2369b0 2018-12-24 stsp err = got_privsep_send_blob_outfd(ibuf, outfd_child);
923 41496140 2019-02-21 stsp if (err)
924 9f2369b0 2018-12-24 stsp return err;
925 9f2369b0 2018-12-24 stsp
926 ac544f8c 2019-01-13 stsp err = got_privsep_recv_blob(outbuf, size, hdrlen, ibuf);
927 9f2369b0 2018-12-24 stsp if (err)
928 9f2369b0 2018-12-24 stsp return err;
929 9f2369b0 2018-12-24 stsp
930 9f2369b0 2018-12-24 stsp if (lseek(outfd, SEEK_SET, 0) == -1)
931 638f9024 2019-05-13 stsp return got_error_from_errno("lseek");
932 9f2369b0 2018-12-24 stsp
933 9f2369b0 2018-12-24 stsp return err;
934 9f2369b0 2018-12-24 stsp }
935 9f2369b0 2018-12-24 stsp
936 9f2369b0 2018-12-24 stsp static const struct got_error *
937 ac544f8c 2019-01-13 stsp read_blob_privsep(uint8_t **outbuf, size_t *size, size_t *hdrlen,
938 9f2369b0 2018-12-24 stsp int outfd, int infd, struct got_repository *repo)
939 9f2369b0 2018-12-24 stsp {
940 9f2369b0 2018-12-24 stsp int imsg_fds[2];
941 9f2369b0 2018-12-24 stsp pid_t pid;
942 9f2369b0 2018-12-24 stsp struct imsgbuf *ibuf;
943 9f2369b0 2018-12-24 stsp
944 9f2369b0 2018-12-24 stsp if (repo->privsep_children[GOT_REPO_PRIVSEP_CHILD_BLOB].imsg_fd != -1) {
945 9f2369b0 2018-12-24 stsp ibuf = repo->privsep_children[GOT_REPO_PRIVSEP_CHILD_BLOB].ibuf;
946 ac544f8c 2019-01-13 stsp return request_blob(outbuf, size, hdrlen, outfd, infd, ibuf);
947 9f2369b0 2018-12-24 stsp }
948 9f2369b0 2018-12-24 stsp
949 9f2369b0 2018-12-24 stsp ibuf = calloc(1, sizeof(*ibuf));
950 9f2369b0 2018-12-24 stsp if (ibuf == NULL)
951 638f9024 2019-05-13 stsp return got_error_from_errno("calloc");
952 9f2369b0 2018-12-24 stsp
953 9f2369b0 2018-12-24 stsp if (socketpair(AF_UNIX, SOCK_STREAM, PF_UNSPEC, imsg_fds) == -1)
954 638f9024 2019-05-13 stsp return got_error_from_errno("socketpair");
955 9f2369b0 2018-12-24 stsp
956 9f2369b0 2018-12-24 stsp pid = fork();
957 9f2369b0 2018-12-24 stsp if (pid == -1)
958 638f9024 2019-05-13 stsp return got_error_from_errno("fork");
959 9f2369b0 2018-12-24 stsp else if (pid == 0) {
960 9f2369b0 2018-12-24 stsp exec_privsep_child(imsg_fds, GOT_PATH_PROG_READ_BLOB,
961 9f2369b0 2018-12-24 stsp repo->path);
962 9f2369b0 2018-12-24 stsp /* not reached */
963 9f2369b0 2018-12-24 stsp }
964 9f2369b0 2018-12-24 stsp
965 3a6ce05a 2019-02-11 stsp if (close(imsg_fds[1]) != 0)
966 638f9024 2019-05-13 stsp return got_error_from_errno("close");
967 9f2369b0 2018-12-24 stsp repo->privsep_children[GOT_REPO_PRIVSEP_CHILD_BLOB].imsg_fd =
968 9f2369b0 2018-12-24 stsp imsg_fds[0];
969 9f2369b0 2018-12-24 stsp repo->privsep_children[GOT_REPO_PRIVSEP_CHILD_BLOB].pid = pid;
970 9f2369b0 2018-12-24 stsp imsg_init(ibuf, imsg_fds[0]);
971 9f2369b0 2018-12-24 stsp repo->privsep_children[GOT_REPO_PRIVSEP_CHILD_BLOB].ibuf = ibuf;
972 9f2369b0 2018-12-24 stsp
973 ac544f8c 2019-01-13 stsp return request_blob(outbuf, size, hdrlen, outfd, infd, ibuf);
974 ebc55e2d 2018-12-24 stsp }
975 68482ea3 2017-11-27 stsp
976 ebc55e2d 2018-12-24 stsp static const struct got_error *
977 ebc55e2d 2018-12-24 stsp open_blob(struct got_blob_object **blob, struct got_repository *repo,
978 ebc55e2d 2018-12-24 stsp struct got_object_id *id, size_t blocksize)
979 ebc55e2d 2018-12-24 stsp {
980 ebc55e2d 2018-12-24 stsp const struct got_error *err = NULL;
981 ebc55e2d 2018-12-24 stsp struct got_packidx *packidx = NULL;
982 ebc55e2d 2018-12-24 stsp int idx;
983 8d2c5ea3 2019-08-13 stsp char *path_packfile = NULL;
984 ac544f8c 2019-01-13 stsp uint8_t *outbuf;
985 e82b1d81 2019-07-27 stsp int outfd;
986 ebc55e2d 2018-12-24 stsp size_t size, hdrlen;
987 ebc55e2d 2018-12-24 stsp struct stat sb;
988 ebc55e2d 2018-12-24 stsp
989 68482ea3 2017-11-27 stsp *blob = calloc(1, sizeof(**blob));
990 4558fcd4 2018-01-14 stsp if (*blob == NULL)
991 638f9024 2019-05-13 stsp return got_error_from_errno("calloc");
992 68482ea3 2017-11-27 stsp
993 55da3778 2018-09-10 stsp outfd = got_opentempfd();
994 55da3778 2018-09-10 stsp if (outfd == -1)
995 638f9024 2019-05-13 stsp return got_error_from_errno("got_opentempfd");
996 55da3778 2018-09-10 stsp
997 062ebb78 2018-07-12 stsp (*blob)->read_buf = malloc(blocksize);
998 15c8b0e6 2018-04-24 stsp if ((*blob)->read_buf == NULL) {
999 638f9024 2019-05-13 stsp err = got_error_from_errno("malloc");
1000 c7254d79 2018-04-24 stsp goto done;
1001 15c8b0e6 2018-04-24 stsp }
1002 ebc55e2d 2018-12-24 stsp
1003 e82b1d81 2019-07-27 stsp err = got_repo_search_packidx(&packidx, &idx, repo, id);
1004 e82b1d81 2019-07-27 stsp if (err == NULL) {
1005 ebc55e2d 2018-12-24 stsp struct got_pack *pack = NULL;
1006 34f480ff 2019-07-27 stsp
1007 ebc55e2d 2018-12-24 stsp err = get_packfile_path(&path_packfile, packidx);
1008 ebc55e2d 2018-12-24 stsp if (err)
1009 ebc55e2d 2018-12-24 stsp goto done;
1010 ebc55e2d 2018-12-24 stsp
1011 ebc55e2d 2018-12-24 stsp pack = got_repo_get_cached_pack(repo, path_packfile);
1012 55da3778 2018-09-10 stsp if (pack == NULL) {
1013 ebc55e2d 2018-12-24 stsp err = got_repo_cache_pack(&pack, repo, path_packfile,
1014 ebc55e2d 2018-12-24 stsp packidx);
1015 55da3778 2018-09-10 stsp if (err)
1016 55da3778 2018-09-10 stsp goto done;
1017 55da3778 2018-09-10 stsp }
1018 ac544f8c 2019-01-13 stsp err = read_packed_blob_privsep(&outbuf, &size, &hdrlen, outfd,
1019 ac544f8c 2019-01-13 stsp pack, packidx, idx, id);
1020 e82b1d81 2019-07-27 stsp } else if (err->code == GOT_ERR_NO_OBJ) {
1021 e82b1d81 2019-07-27 stsp int infd;
1022 e82b1d81 2019-07-27 stsp
1023 e82b1d81 2019-07-27 stsp err = open_loose_object(&infd, id, repo);
1024 e82b1d81 2019-07-27 stsp if (err)
1025 e82b1d81 2019-07-27 stsp goto done;
1026 ac544f8c 2019-01-13 stsp err = read_blob_privsep(&outbuf, &size, &hdrlen, outfd, infd,
1027 ac544f8c 2019-01-13 stsp repo);
1028 e82b1d81 2019-07-27 stsp }
1029 ebc55e2d 2018-12-24 stsp if (err)
1030 55da3778 2018-09-10 stsp goto done;
1031 2967a784 2018-04-24 stsp
1032 de060dff 2018-12-24 stsp if (hdrlen > size) {
1033 ebc55e2d 2018-12-24 stsp err = got_error(GOT_ERR_BAD_OBJ_HDR);
1034 ebc55e2d 2018-12-24 stsp goto done;
1035 ebc55e2d 2018-12-24 stsp }
1036 ebc55e2d 2018-12-24 stsp
1037 ac544f8c 2019-01-13 stsp if (outbuf) {
1038 3a6ce05a 2019-02-11 stsp if (close(outfd) != 0 && err == NULL)
1039 638f9024 2019-05-13 stsp err = got_error_from_errno("close");
1040 ac544f8c 2019-01-13 stsp outfd = -1;
1041 ac544f8c 2019-01-13 stsp (*blob)->f = fmemopen(outbuf, size, "rb");
1042 ac544f8c 2019-01-13 stsp if ((*blob)->f == NULL) {
1043 638f9024 2019-05-13 stsp err = got_error_from_errno("fmemopen");
1044 ac544f8c 2019-01-13 stsp free(outbuf);
1045 ac544f8c 2019-01-13 stsp goto done;
1046 ac544f8c 2019-01-13 stsp }
1047 ac544f8c 2019-01-13 stsp (*blob)->data = outbuf;
1048 ac544f8c 2019-01-13 stsp } else {
1049 ac544f8c 2019-01-13 stsp if (fstat(outfd, &sb) == -1) {
1050 638f9024 2019-05-13 stsp err = got_error_from_errno("fstat");
1051 ac544f8c 2019-01-13 stsp goto done;
1052 ac544f8c 2019-01-13 stsp }
1053 ac544f8c 2019-01-13 stsp
1054 ac544f8c 2019-01-13 stsp if (sb.st_size != size) {
1055 ac544f8c 2019-01-13 stsp err = got_error(GOT_ERR_PRIVSEP_LEN);
1056 ac544f8c 2019-01-13 stsp goto done;
1057 ac544f8c 2019-01-13 stsp }
1058 ac544f8c 2019-01-13 stsp
1059 ac544f8c 2019-01-13 stsp (*blob)->f = fdopen(outfd, "rb");
1060 ac544f8c 2019-01-13 stsp if ((*blob)->f == NULL) {
1061 638f9024 2019-05-13 stsp err = got_error_from_errno("fdopen");
1062 ac544f8c 2019-01-13 stsp close(outfd);
1063 ac544f8c 2019-01-13 stsp outfd = -1;
1064 ac544f8c 2019-01-13 stsp goto done;
1065 ac544f8c 2019-01-13 stsp }
1066 68482ea3 2017-11-27 stsp }
1067 68482ea3 2017-11-27 stsp
1068 ebc55e2d 2018-12-24 stsp (*blob)->hdrlen = hdrlen;
1069 eb651edf 2018-02-11 stsp (*blob)->blocksize = blocksize;
1070 ebc55e2d 2018-12-24 stsp memcpy(&(*blob)->id.sha1, id->sha1, SHA1_DIGEST_LENGTH);
1071 7d283eee 2017-11-29 stsp
1072 c7254d79 2018-04-24 stsp done:
1073 8d2c5ea3 2019-08-13 stsp free(path_packfile);
1074 55da3778 2018-09-10 stsp if (err) {
1075 55da3778 2018-09-10 stsp if (*blob) {
1076 7baf5860 2019-03-19 stsp got_object_blob_close(*blob);
1077 55da3778 2018-09-10 stsp *blob = NULL;
1078 55da3778 2018-09-10 stsp } else if (outfd != -1)
1079 55da3778 2018-09-10 stsp close(outfd);
1080 a19581a2 2018-06-21 stsp }
1081 a19581a2 2018-06-21 stsp return err;
1082 a19581a2 2018-06-21 stsp }
1083 a19581a2 2018-06-21 stsp
1084 a19581a2 2018-06-21 stsp const struct got_error *
1085 a19581a2 2018-06-21 stsp got_object_open_as_blob(struct got_blob_object **blob,
1086 a19581a2 2018-06-21 stsp struct got_repository *repo, struct got_object_id *id,
1087 a19581a2 2018-06-21 stsp size_t blocksize)
1088 a19581a2 2018-06-21 stsp {
1089 ebc55e2d 2018-12-24 stsp return open_blob(blob, repo, id, blocksize);
1090 ebc55e2d 2018-12-24 stsp }
1091 835e0dbd 2018-06-21 stsp
1092 ebc55e2d 2018-12-24 stsp const struct got_error *
1093 ebc55e2d 2018-12-24 stsp got_object_blob_open(struct got_blob_object **blob,
1094 ebc55e2d 2018-12-24 stsp struct got_repository *repo, struct got_object *obj, size_t blocksize)
1095 ebc55e2d 2018-12-24 stsp {
1096 ebc55e2d 2018-12-24 stsp return open_blob(blob, repo, got_object_get_id(obj), blocksize);
1097 0ffeb3c2 2017-11-26 stsp }
1098 68482ea3 2017-11-27 stsp
1099 fb43ecf1 2019-02-11 stsp const struct got_error *
1100 68482ea3 2017-11-27 stsp got_object_blob_close(struct got_blob_object *blob)
1101 68482ea3 2017-11-27 stsp {
1102 fb43ecf1 2019-02-11 stsp const struct got_error *err = NULL;
1103 15c8b0e6 2018-04-24 stsp free(blob->read_buf);
1104 7baf5860 2019-03-19 stsp if (blob->f && fclose(blob->f) != 0)
1105 638f9024 2019-05-13 stsp err = got_error_from_errno("fclose");
1106 ac544f8c 2019-01-13 stsp free(blob->data);
1107 68482ea3 2017-11-27 stsp free(blob);
1108 fb43ecf1 2019-02-11 stsp return err;
1109 f934cf2c 2018-02-12 stsp }
1110 f934cf2c 2018-02-12 stsp
1111 f934cf2c 2018-02-12 stsp char *
1112 f934cf2c 2018-02-12 stsp got_object_blob_id_str(struct got_blob_object *blob, char *buf, size_t size)
1113 f934cf2c 2018-02-12 stsp {
1114 f934cf2c 2018-02-12 stsp return got_sha1_digest_to_str(blob->id.sha1, buf, size);
1115 f934cf2c 2018-02-12 stsp }
1116 f934cf2c 2018-02-12 stsp
1117 f934cf2c 2018-02-12 stsp size_t
1118 f934cf2c 2018-02-12 stsp got_object_blob_get_hdrlen(struct got_blob_object *blob)
1119 f934cf2c 2018-02-12 stsp {
1120 f934cf2c 2018-02-12 stsp return blob->hdrlen;
1121 68482ea3 2017-11-27 stsp }
1122 68482ea3 2017-11-27 stsp
1123 f934cf2c 2018-02-12 stsp const uint8_t *
1124 f934cf2c 2018-02-12 stsp got_object_blob_get_read_buf(struct got_blob_object *blob)
1125 f934cf2c 2018-02-12 stsp {
1126 f934cf2c 2018-02-12 stsp return blob->read_buf;
1127 f934cf2c 2018-02-12 stsp }
1128 f934cf2c 2018-02-12 stsp
1129 68482ea3 2017-11-27 stsp const struct got_error *
1130 eb651edf 2018-02-11 stsp got_object_blob_read_block(size_t *outlenp, struct got_blob_object *blob)
1131 68482ea3 2017-11-27 stsp {
1132 eb651edf 2018-02-11 stsp size_t n;
1133 eb651edf 2018-02-11 stsp
1134 eb651edf 2018-02-11 stsp n = fread(blob->read_buf, 1, blob->blocksize, blob->f);
1135 eb651edf 2018-02-11 stsp if (n == 0 && ferror(blob->f))
1136 eb651edf 2018-02-11 stsp return got_ferror(blob->f, GOT_ERR_IO);
1137 eb651edf 2018-02-11 stsp *outlenp = n;
1138 35e9ba5d 2018-06-21 stsp return NULL;
1139 35e9ba5d 2018-06-21 stsp }
1140 35e9ba5d 2018-06-21 stsp
1141 35e9ba5d 2018-06-21 stsp const struct got_error *
1142 f595d9bd 2019-08-14 stsp got_object_blob_dump_to_file(size_t *filesize, int *nlines,
1143 6c4c42e0 2019-06-24 stsp off_t **line_offsets, FILE *outfile, struct got_blob_object *blob)
1144 35e9ba5d 2018-06-21 stsp {
1145 35e9ba5d 2018-06-21 stsp const struct got_error *err = NULL;
1146 b6752625 2018-12-24 stsp size_t n, len, hdrlen;
1147 84451b3e 2018-07-10 stsp const uint8_t *buf;
1148 84451b3e 2018-07-10 stsp int i;
1149 6c4c42e0 2019-06-24 stsp size_t noffsets = 0;
1150 f595d9bd 2019-08-14 stsp off_t off = 0, total_len = 0;
1151 84451b3e 2018-07-10 stsp
1152 6c4c42e0 2019-06-24 stsp if (line_offsets)
1153 6c4c42e0 2019-06-24 stsp *line_offsets = NULL;
1154 f595d9bd 2019-08-14 stsp if (filesize)
1155 f595d9bd 2019-08-14 stsp *filesize = 0;
1156 84451b3e 2018-07-10 stsp if (nlines)
1157 84451b3e 2018-07-10 stsp *nlines = 0;
1158 35e9ba5d 2018-06-21 stsp
1159 35e9ba5d 2018-06-21 stsp hdrlen = got_object_blob_get_hdrlen(blob);
1160 35e9ba5d 2018-06-21 stsp do {
1161 35e9ba5d 2018-06-21 stsp err = got_object_blob_read_block(&len, blob);
1162 35e9ba5d 2018-06-21 stsp if (err)
1163 35e9ba5d 2018-06-21 stsp return err;
1164 35e9ba5d 2018-06-21 stsp if (len == 0)
1165 35e9ba5d 2018-06-21 stsp break;
1166 84451b3e 2018-07-10 stsp buf = got_object_blob_get_read_buf(blob);
1167 b02560ec 2019-08-19 stsp i = hdrlen;
1168 78695fb7 2019-08-12 stsp if (line_offsets && nlines) {
1169 78695fb7 2019-08-12 stsp if (*line_offsets == NULL) {
1170 78695fb7 2019-08-12 stsp /* Have some data but perhaps no '\n'. */
1171 78695fb7 2019-08-12 stsp noffsets = 1;
1172 78695fb7 2019-08-12 stsp *nlines = 1;
1173 f595d9bd 2019-08-14 stsp *line_offsets = calloc(1, sizeof(**line_offsets));
1174 78695fb7 2019-08-12 stsp if (*line_offsets == NULL)
1175 78695fb7 2019-08-12 stsp return got_error_from_errno("malloc");
1176 b02560ec 2019-08-19 stsp
1177 b02560ec 2019-08-19 stsp /* Skip forward over end of first line. */
1178 b02560ec 2019-08-19 stsp while (i < len) {
1179 b02560ec 2019-08-19 stsp if (buf[i] == '\n')
1180 b02560ec 2019-08-19 stsp break;
1181 b02560ec 2019-08-19 stsp i++;
1182 b02560ec 2019-08-19 stsp }
1183 b02560ec 2019-08-19 stsp }
1184 b02560ec 2019-08-19 stsp /* Scan '\n' offsets in remaining chunk of data. */
1185 b02560ec 2019-08-19 stsp while (i < len) {
1186 b02560ec 2019-08-19 stsp if (buf[i] != '\n') {
1187 b02560ec 2019-08-19 stsp i++;
1188 f595d9bd 2019-08-14 stsp continue;
1189 b02560ec 2019-08-19 stsp }
1190 f595d9bd 2019-08-14 stsp (*nlines)++;
1191 78695fb7 2019-08-12 stsp if (noffsets < *nlines) {
1192 78695fb7 2019-08-12 stsp off_t *o = recallocarray(*line_offsets,
1193 78695fb7 2019-08-12 stsp noffsets, *nlines,
1194 78695fb7 2019-08-12 stsp sizeof(**line_offsets));
1195 78695fb7 2019-08-12 stsp if (o == NULL) {
1196 78695fb7 2019-08-12 stsp free(*line_offsets);
1197 78695fb7 2019-08-12 stsp *line_offsets = NULL;
1198 78695fb7 2019-08-12 stsp return got_error_from_errno(
1199 78695fb7 2019-08-12 stsp "recallocarray");
1200 78695fb7 2019-08-12 stsp }
1201 78695fb7 2019-08-12 stsp *line_offsets = o;
1202 78695fb7 2019-08-12 stsp noffsets = *nlines;
1203 78695fb7 2019-08-12 stsp }
1204 f595d9bd 2019-08-14 stsp off = total_len + i - hdrlen + 1;
1205 f595d9bd 2019-08-14 stsp (*line_offsets)[*nlines - 1] = off;
1206 b02560ec 2019-08-19 stsp i++;
1207 6c4c42e0 2019-06-24 stsp }
1208 84451b3e 2018-07-10 stsp }
1209 35e9ba5d 2018-06-21 stsp /* Skip blob object header first time around. */
1210 454a6b59 2018-12-24 stsp n = fwrite(buf + hdrlen, 1, len - hdrlen, outfile);
1211 b6752625 2018-12-24 stsp if (n != len - hdrlen)
1212 b6752625 2018-12-24 stsp return got_ferror(outfile, GOT_ERR_IO);
1213 f595d9bd 2019-08-14 stsp total_len += len - hdrlen;
1214 35e9ba5d 2018-06-21 stsp hdrlen = 0;
1215 35e9ba5d 2018-06-21 stsp } while (len != 0);
1216 35e9ba5d 2018-06-21 stsp
1217 cbe7f848 2019-02-11 stsp if (fflush(outfile) != 0)
1218 638f9024 2019-05-13 stsp return got_error_from_errno("fflush");
1219 35e9ba5d 2018-06-21 stsp rewind(outfile);
1220 35e9ba5d 2018-06-21 stsp
1221 f595d9bd 2019-08-14 stsp if (filesize)
1222 f595d9bd 2019-08-14 stsp *filesize = total_len;
1223 f595d9bd 2019-08-14 stsp
1224 776d4d29 2018-06-17 stsp return NULL;
1225 f4a881ce 2018-11-17 stsp }
1226 f4a881ce 2018-11-17 stsp
1227 f4a881ce 2018-11-17 stsp static const struct got_error *
1228 268f7291 2018-12-24 stsp request_packed_tag(struct got_tag_object **tag, struct got_pack *pack,
1229 268f7291 2018-12-24 stsp int pack_idx, struct got_object_id *id)
1230 a158c901 2018-12-23 stsp {
1231 a158c901 2018-12-23 stsp const struct got_error *err = NULL;
1232 a158c901 2018-12-23 stsp
1233 268f7291 2018-12-24 stsp err = got_privsep_send_tag_req(pack->privsep_child->ibuf, -1, id,
1234 268f7291 2018-12-24 stsp pack_idx);
1235 a158c901 2018-12-23 stsp if (err)
1236 a158c901 2018-12-23 stsp return err;
1237 a158c901 2018-12-23 stsp
1238 a158c901 2018-12-23 stsp return got_privsep_recv_tag(tag, pack->privsep_child->ibuf);
1239 268f7291 2018-12-24 stsp }
1240 268f7291 2018-12-24 stsp
1241 268f7291 2018-12-24 stsp static const struct got_error *
1242 268f7291 2018-12-24 stsp read_packed_tag_privsep(struct got_tag_object **tag,
1243 268f7291 2018-12-24 stsp struct got_pack *pack, struct got_packidx *packidx, int idx,
1244 268f7291 2018-12-24 stsp struct got_object_id *id)
1245 268f7291 2018-12-24 stsp {
1246 268f7291 2018-12-24 stsp const struct got_error *err = NULL;
1247 268f7291 2018-12-24 stsp
1248 268f7291 2018-12-24 stsp if (pack->privsep_child)
1249 268f7291 2018-12-24 stsp return request_packed_tag(tag, pack, idx, id);
1250 268f7291 2018-12-24 stsp
1251 268f7291 2018-12-24 stsp err = start_pack_privsep_child(pack, packidx);
1252 268f7291 2018-12-24 stsp if (err)
1253 268f7291 2018-12-24 stsp return err;
1254 268f7291 2018-12-24 stsp
1255 268f7291 2018-12-24 stsp return request_packed_tag(tag, pack, idx, id);
1256 a158c901 2018-12-23 stsp }
1257 9f2369b0 2018-12-24 stsp
1258 9f2369b0 2018-12-24 stsp static const struct got_error *
1259 9f2369b0 2018-12-24 stsp request_tag(struct got_tag_object **tag, struct got_repository *repo,
1260 9f2369b0 2018-12-24 stsp int fd)
1261 9f2369b0 2018-12-24 stsp {
1262 9f2369b0 2018-12-24 stsp const struct got_error *err = NULL;
1263 9f2369b0 2018-12-24 stsp struct imsgbuf *ibuf;
1264 9f2369b0 2018-12-24 stsp
1265 9f2369b0 2018-12-24 stsp ibuf = repo->privsep_children[GOT_REPO_PRIVSEP_CHILD_TAG].ibuf;
1266 9f2369b0 2018-12-24 stsp
1267 9f2369b0 2018-12-24 stsp err = got_privsep_send_tag_req(ibuf, fd, NULL, -1);
1268 9f2369b0 2018-12-24 stsp if (err)
1269 9f2369b0 2018-12-24 stsp return err;
1270 9f2369b0 2018-12-24 stsp
1271 9f2369b0 2018-12-24 stsp return got_privsep_recv_tag(tag, ibuf);
1272 9f2369b0 2018-12-24 stsp }
1273 9f2369b0 2018-12-24 stsp
1274 9f2369b0 2018-12-24 stsp static const struct got_error *
1275 9f2369b0 2018-12-24 stsp read_tag_privsep(struct got_tag_object **tag, int obj_fd,
1276 9f2369b0 2018-12-24 stsp struct got_repository *repo)
1277 9f2369b0 2018-12-24 stsp {
1278 9f2369b0 2018-12-24 stsp int imsg_fds[2];
1279 9f2369b0 2018-12-24 stsp pid_t pid;
1280 9f2369b0 2018-12-24 stsp struct imsgbuf *ibuf;
1281 9f2369b0 2018-12-24 stsp
1282 9f2369b0 2018-12-24 stsp if (repo->privsep_children[GOT_REPO_PRIVSEP_CHILD_TAG].imsg_fd != -1)
1283 9f2369b0 2018-12-24 stsp return request_tag(tag, repo, obj_fd);
1284 9f2369b0 2018-12-24 stsp
1285 9f2369b0 2018-12-24 stsp ibuf = calloc(1, sizeof(*ibuf));
1286 9f2369b0 2018-12-24 stsp if (ibuf == NULL)
1287 638f9024 2019-05-13 stsp return got_error_from_errno("calloc");
1288 9f2369b0 2018-12-24 stsp
1289 9f2369b0 2018-12-24 stsp if (socketpair(AF_UNIX, SOCK_STREAM, PF_UNSPEC, imsg_fds) == -1)
1290 638f9024 2019-05-13 stsp return got_error_from_errno("socketpair");
1291 9f2369b0 2018-12-24 stsp
1292 9f2369b0 2018-12-24 stsp pid = fork();
1293 9f2369b0 2018-12-24 stsp if (pid == -1)
1294 638f9024 2019-05-13 stsp return got_error_from_errno("fork");
1295 9f2369b0 2018-12-24 stsp else if (pid == 0) {
1296 9f2369b0 2018-12-24 stsp exec_privsep_child(imsg_fds, GOT_PATH_PROG_READ_TAG,
1297 9f2369b0 2018-12-24 stsp repo->path);
1298 9f2369b0 2018-12-24 stsp /* not reached */
1299 9f2369b0 2018-12-24 stsp }
1300 9f2369b0 2018-12-24 stsp
1301 3a6ce05a 2019-02-11 stsp if (close(imsg_fds[1]) != 0)
1302 638f9024 2019-05-13 stsp return got_error_from_errno("close");
1303 9f2369b0 2018-12-24 stsp repo->privsep_children[GOT_REPO_PRIVSEP_CHILD_TAG].imsg_fd =
1304 9f2369b0 2018-12-24 stsp imsg_fds[0];
1305 9f2369b0 2018-12-24 stsp repo->privsep_children[GOT_REPO_PRIVSEP_CHILD_TAG].pid = pid;
1306 9f2369b0 2018-12-24 stsp imsg_init(ibuf, imsg_fds[0]);
1307 9f2369b0 2018-12-24 stsp repo->privsep_children[GOT_REPO_PRIVSEP_CHILD_TAG].ibuf = ibuf;
1308 a158c901 2018-12-23 stsp
1309 9f2369b0 2018-12-24 stsp return request_tag(tag, repo, obj_fd);
1310 9f2369b0 2018-12-24 stsp }
1311 a158c901 2018-12-23 stsp
1312 a158c901 2018-12-23 stsp static const struct got_error *
1313 268f7291 2018-12-24 stsp open_tag(struct got_tag_object **tag, struct got_repository *repo,
1314 268f7291 2018-12-24 stsp struct got_object_id *id, int check_cache)
1315 f4a881ce 2018-11-17 stsp {
1316 f4a881ce 2018-11-17 stsp const struct got_error *err = NULL;
1317 268f7291 2018-12-24 stsp struct got_packidx *packidx = NULL;
1318 e82b1d81 2019-07-27 stsp int idx;
1319 8d2c5ea3 2019-08-13 stsp char *path_packfile = NULL;
1320 5d844a1e 2019-08-13 stsp struct got_object *obj = NULL;
1321 5d844a1e 2019-08-13 stsp int obj_type = GOT_OBJ_TYPE_ANY;
1322 f4a881ce 2018-11-17 stsp
1323 f4a881ce 2018-11-17 stsp if (check_cache) {
1324 268f7291 2018-12-24 stsp *tag = got_repo_get_cached_tag(repo, id);
1325 f4a881ce 2018-11-17 stsp if (*tag != NULL) {
1326 f4a881ce 2018-11-17 stsp (*tag)->refcnt++;
1327 f4a881ce 2018-11-17 stsp return NULL;
1328 f4a881ce 2018-11-17 stsp }
1329 f4a881ce 2018-11-17 stsp } else
1330 f4a881ce 2018-11-17 stsp *tag = NULL;
1331 f4a881ce 2018-11-17 stsp
1332 e82b1d81 2019-07-27 stsp err = got_repo_search_packidx(&packidx, &idx, repo, id);
1333 e82b1d81 2019-07-27 stsp if (err == NULL) {
1334 268f7291 2018-12-24 stsp struct got_pack *pack = NULL;
1335 f4a881ce 2018-11-17 stsp
1336 268f7291 2018-12-24 stsp err = get_packfile_path(&path_packfile, packidx);
1337 268f7291 2018-12-24 stsp if (err)
1338 268f7291 2018-12-24 stsp return err;
1339 268f7291 2018-12-24 stsp
1340 268f7291 2018-12-24 stsp pack = got_repo_get_cached_pack(repo, path_packfile);
1341 f4a881ce 2018-11-17 stsp if (pack == NULL) {
1342 e82b1d81 2019-07-27 stsp err = got_repo_cache_pack(&pack, repo, path_packfile,
1343 e82b1d81 2019-07-27 stsp packidx);
1344 f4a881ce 2018-11-17 stsp if (err)
1345 8d2c5ea3 2019-08-13 stsp goto done;
1346 f4a881ce 2018-11-17 stsp }
1347 5d844a1e 2019-08-13 stsp
1348 5d844a1e 2019-08-13 stsp /* Beware of "leightweight" tags: Check object type first. */
1349 5d844a1e 2019-08-13 stsp err = read_packed_object_privsep(&obj, repo, pack, packidx,
1350 5d844a1e 2019-08-13 stsp idx, id);
1351 5d844a1e 2019-08-13 stsp if (err)
1352 5d844a1e 2019-08-13 stsp goto done;
1353 5d844a1e 2019-08-13 stsp obj_type = obj->type;
1354 5d844a1e 2019-08-13 stsp got_object_close(obj);
1355 5d844a1e 2019-08-13 stsp if (obj_type != GOT_OBJ_TYPE_TAG) {
1356 5d844a1e 2019-08-13 stsp err = got_error(GOT_ERR_OBJ_TYPE);
1357 5d844a1e 2019-08-13 stsp goto done;
1358 5d844a1e 2019-08-13 stsp }
1359 5d844a1e 2019-08-13 stsp err = read_packed_tag_privsep(tag, pack, packidx, idx, id);
1360 e82b1d81 2019-07-27 stsp } else if (err->code == GOT_ERR_NO_OBJ) {
1361 e82b1d81 2019-07-27 stsp int fd;
1362 e82b1d81 2019-07-27 stsp
1363 e82b1d81 2019-07-27 stsp err = open_loose_object(&fd, id, repo);
1364 e82b1d81 2019-07-27 stsp if (err)
1365 e82b1d81 2019-07-27 stsp return err;
1366 5d844a1e 2019-08-13 stsp err = read_object_header_privsep(&obj, repo, fd);
1367 5d844a1e 2019-08-13 stsp if (err)
1368 5d844a1e 2019-08-13 stsp return err;
1369 5d844a1e 2019-08-13 stsp obj_type = obj->type;
1370 5d844a1e 2019-08-13 stsp got_object_close(obj);
1371 5d844a1e 2019-08-13 stsp if (obj_type != GOT_OBJ_TYPE_TAG)
1372 5d844a1e 2019-08-13 stsp return got_error(GOT_ERR_OBJ_TYPE);
1373 5d844a1e 2019-08-13 stsp
1374 5d844a1e 2019-08-13 stsp err = open_loose_object(&fd, id, repo);
1375 5d844a1e 2019-08-13 stsp if (err)
1376 5d844a1e 2019-08-13 stsp return err;
1377 9f2369b0 2018-12-24 stsp err = read_tag_privsep(tag, fd, repo);
1378 e82b1d81 2019-07-27 stsp }
1379 f4a881ce 2018-11-17 stsp
1380 f4a881ce 2018-11-17 stsp if (err == NULL) {
1381 f4a881ce 2018-11-17 stsp (*tag)->refcnt++;
1382 268f7291 2018-12-24 stsp err = got_repo_cache_tag(repo, id, *tag);
1383 f4a881ce 2018-11-17 stsp }
1384 8d2c5ea3 2019-08-13 stsp done:
1385 8d2c5ea3 2019-08-13 stsp free(path_packfile);
1386 f4a881ce 2018-11-17 stsp return err;
1387 f4a881ce 2018-11-17 stsp }
1388 f4a881ce 2018-11-17 stsp
1389 f4a881ce 2018-11-17 stsp const struct got_error *
1390 f4a881ce 2018-11-17 stsp got_object_open_as_tag(struct got_tag_object **tag,
1391 f4a881ce 2018-11-17 stsp struct got_repository *repo, struct got_object_id *id)
1392 f4a881ce 2018-11-17 stsp {
1393 f4a881ce 2018-11-17 stsp *tag = got_repo_get_cached_tag(repo, id);
1394 f4a881ce 2018-11-17 stsp if (*tag != NULL) {
1395 f4a881ce 2018-11-17 stsp (*tag)->refcnt++;
1396 f4a881ce 2018-11-17 stsp return NULL;
1397 f4a881ce 2018-11-17 stsp }
1398 f4a881ce 2018-11-17 stsp
1399 268f7291 2018-12-24 stsp return open_tag(tag, repo, id, 0);
1400 f4a881ce 2018-11-17 stsp }
1401 f4a881ce 2018-11-17 stsp
1402 f4a881ce 2018-11-17 stsp const struct got_error *
1403 f4a881ce 2018-11-17 stsp got_object_tag_open(struct got_tag_object **tag,
1404 f4a881ce 2018-11-17 stsp struct got_repository *repo, struct got_object *obj)
1405 f4a881ce 2018-11-17 stsp {
1406 268f7291 2018-12-24 stsp return open_tag(tag, repo, got_object_get_id(obj), 1);
1407 d24820bf 2019-08-11 stsp }
1408 d24820bf 2019-08-11 stsp
1409 d24820bf 2019-08-11 stsp const char *
1410 d24820bf 2019-08-11 stsp got_object_tag_get_name(struct got_tag_object *tag)
1411 d24820bf 2019-08-11 stsp {
1412 d24820bf 2019-08-11 stsp return tag->tag;
1413 0bd18d37 2019-02-01 stsp }
1414 0bd18d37 2019-02-01 stsp
1415 0bd18d37 2019-02-01 stsp int
1416 0bd18d37 2019-02-01 stsp got_object_tag_get_object_type(struct got_tag_object *tag)
1417 0bd18d37 2019-02-01 stsp {
1418 0bd18d37 2019-02-01 stsp return tag->obj_type;
1419 0bd18d37 2019-02-01 stsp }
1420 0bd18d37 2019-02-01 stsp
1421 0bd18d37 2019-02-01 stsp struct got_object_id *
1422 0bd18d37 2019-02-01 stsp got_object_tag_get_object_id(struct got_tag_object *tag)
1423 0bd18d37 2019-02-01 stsp {
1424 0bd18d37 2019-02-01 stsp return &tag->id;
1425 01073a5d 2019-08-22 stsp }
1426 01073a5d 2019-08-22 stsp
1427 01073a5d 2019-08-22 stsp time_t
1428 01073a5d 2019-08-22 stsp got_object_tag_get_tagger_time(struct got_tag_object *tag)
1429 01073a5d 2019-08-22 stsp {
1430 01073a5d 2019-08-22 stsp return tag->tagger_time;
1431 01073a5d 2019-08-22 stsp }
1432 01073a5d 2019-08-22 stsp
1433 01073a5d 2019-08-22 stsp time_t
1434 01073a5d 2019-08-22 stsp got_object_tag_get_tagger_gmtoff(struct got_tag_object *tag)
1435 01073a5d 2019-08-22 stsp {
1436 01073a5d 2019-08-22 stsp return tag->tagger_gmtoff;
1437 01073a5d 2019-08-22 stsp }
1438 01073a5d 2019-08-22 stsp
1439 01073a5d 2019-08-22 stsp const char *
1440 01073a5d 2019-08-22 stsp got_object_tag_get_tagger(struct got_tag_object *tag)
1441 01073a5d 2019-08-22 stsp {
1442 01073a5d 2019-08-22 stsp return tag->tagger;
1443 776d4d29 2018-06-17 stsp }
1444 776d4d29 2018-06-17 stsp
1445 01073a5d 2019-08-22 stsp const char *
1446 01073a5d 2019-08-22 stsp got_object_tag_get_message(struct got_tag_object *tag)
1447 01073a5d 2019-08-22 stsp {
1448 01073a5d 2019-08-22 stsp return tag->tagmsg;
1449 01073a5d 2019-08-22 stsp }
1450 01073a5d 2019-08-22 stsp
1451 776d4d29 2018-06-17 stsp static struct got_tree_entry *
1452 65a9bbe9 2018-09-15 stsp find_entry_by_name(struct got_tree_object *tree, const char *name, size_t len)
1453 776d4d29 2018-06-17 stsp {
1454 776d4d29 2018-06-17 stsp struct got_tree_entry *te;
1455 776d4d29 2018-06-17 stsp
1456 63da309a 2018-11-07 stsp /* Note that tree entries are sorted in strncmp() order. */
1457 883f0469 2018-06-23 stsp SIMPLEQ_FOREACH(te, &tree->entries.head, entry) {
1458 63da309a 2018-11-07 stsp int cmp = strncmp(te->name, name, len);
1459 63da309a 2018-11-07 stsp if (cmp < 0)
1460 63da309a 2018-11-07 stsp continue;
1461 63da309a 2018-11-07 stsp if (cmp > 0)
1462 63da309a 2018-11-07 stsp break;
1463 63da309a 2018-11-07 stsp if (te->name[len] == '\0')
1464 776d4d29 2018-06-17 stsp return te;
1465 776d4d29 2018-06-17 stsp }
1466 eb651edf 2018-02-11 stsp return NULL;
1467 a129376b 2019-03-28 stsp }
1468 a129376b 2019-03-28 stsp
1469 a129376b 2019-03-28 stsp const struct got_tree_entry *
1470 a129376b 2019-03-28 stsp got_object_tree_find_entry(struct got_tree_object *tree, const char *name)
1471 a129376b 2019-03-28 stsp {
1472 a129376b 2019-03-28 stsp return find_entry_by_name(tree, name, strlen(name));
1473 776d4d29 2018-06-17 stsp }
1474 776d4d29 2018-06-17 stsp
1475 776d4d29 2018-06-17 stsp const struct got_error *
1476 27d434c2 2018-09-15 stsp got_object_id_by_path(struct got_object_id **id, struct got_repository *repo,
1477 776d4d29 2018-06-17 stsp struct got_object_id *commit_id, const char *path)
1478 776d4d29 2018-06-17 stsp {
1479 776d4d29 2018-06-17 stsp const struct got_error *err = NULL;
1480 776d4d29 2018-06-17 stsp struct got_commit_object *commit = NULL;
1481 776d4d29 2018-06-17 stsp struct got_tree_object *tree = NULL;
1482 db37e2c0 2018-06-21 stsp struct got_tree_entry *te = NULL;
1483 65a9bbe9 2018-09-15 stsp const char *seg, *s;
1484 b7cd37e5 2018-11-18 stsp size_t seglen;
1485 776d4d29 2018-06-17 stsp
1486 27d434c2 2018-09-15 stsp *id = NULL;
1487 776d4d29 2018-06-17 stsp
1488 776d4d29 2018-06-17 stsp err = got_object_open_as_commit(&commit, repo, commit_id);
1489 776d4d29 2018-06-17 stsp if (err)
1490 776d4d29 2018-06-17 stsp goto done;
1491 776d4d29 2018-06-17 stsp
1492 776d4d29 2018-06-17 stsp /* Handle opening of root of commit's tree. */
1493 5e54fb30 2019-05-31 stsp if (got_path_is_root_dir(path)) {
1494 27d434c2 2018-09-15 stsp *id = got_object_id_dup(commit->tree_id);
1495 27d434c2 2018-09-15 stsp if (*id == NULL)
1496 638f9024 2019-05-13 stsp err = got_error_from_errno("got_object_id_dup");
1497 ca008b32 2018-07-22 stsp goto done;
1498 776d4d29 2018-06-17 stsp }
1499 776d4d29 2018-06-17 stsp
1500 776d4d29 2018-06-17 stsp err = got_object_open_as_tree(&tree, repo, commit->tree_id);
1501 776d4d29 2018-06-17 stsp if (err)
1502 776d4d29 2018-06-17 stsp goto done;
1503 776d4d29 2018-06-17 stsp
1504 65a9bbe9 2018-09-15 stsp s = path;
1505 5e54fb30 2019-05-31 stsp while (s[0] == '/')
1506 5e54fb30 2019-05-31 stsp s++;
1507 776d4d29 2018-06-17 stsp seg = s;
1508 65a9bbe9 2018-09-15 stsp seglen = 0;
1509 b7cd37e5 2018-11-18 stsp while (*s) {
1510 776d4d29 2018-06-17 stsp struct got_tree_object *next_tree;
1511 776d4d29 2018-06-17 stsp
1512 776d4d29 2018-06-17 stsp if (*s != '/') {
1513 776d4d29 2018-06-17 stsp s++;
1514 65a9bbe9 2018-09-15 stsp seglen++;
1515 00530cfb 2018-06-21 stsp if (*s)
1516 00530cfb 2018-06-21 stsp continue;
1517 776d4d29 2018-06-17 stsp }
1518 776d4d29 2018-06-17 stsp
1519 65a9bbe9 2018-09-15 stsp te = find_entry_by_name(tree, seg, seglen);
1520 db37e2c0 2018-06-21 stsp if (te == NULL) {
1521 d1451975 2018-11-11 stsp err = got_error(GOT_ERR_NO_TREE_ENTRY);
1522 776d4d29 2018-06-17 stsp goto done;
1523 776d4d29 2018-06-17 stsp }
1524 776d4d29 2018-06-17 stsp
1525 b7cd37e5 2018-11-18 stsp if (*s == '\0')
1526 67606321 2018-06-21 stsp break;
1527 67606321 2018-06-21 stsp
1528 776d4d29 2018-06-17 stsp seg = s + 1;
1529 65a9bbe9 2018-09-15 stsp seglen = 0;
1530 776d4d29 2018-06-17 stsp s++;
1531 776d4d29 2018-06-17 stsp if (*s) {
1532 776d4d29 2018-06-17 stsp err = got_object_open_as_tree(&next_tree, repo,
1533 db37e2c0 2018-06-21 stsp te->id);
1534 db37e2c0 2018-06-21 stsp te = NULL;
1535 776d4d29 2018-06-17 stsp if (err)
1536 776d4d29 2018-06-17 stsp goto done;
1537 776d4d29 2018-06-17 stsp got_object_tree_close(tree);
1538 776d4d29 2018-06-17 stsp tree = next_tree;
1539 776d4d29 2018-06-17 stsp }
1540 776d4d29 2018-06-17 stsp }
1541 776d4d29 2018-06-17 stsp
1542 27d434c2 2018-09-15 stsp if (te) {
1543 27d434c2 2018-09-15 stsp *id = got_object_id_dup(te->id);
1544 27d434c2 2018-09-15 stsp if (*id == NULL)
1545 638f9024 2019-05-13 stsp return got_error_from_errno("got_object_id_dup");
1546 27d434c2 2018-09-15 stsp } else
1547 d1451975 2018-11-11 stsp err = got_error(GOT_ERR_NO_TREE_ENTRY);
1548 776d4d29 2018-06-17 stsp done:
1549 776d4d29 2018-06-17 stsp if (commit)
1550 776d4d29 2018-06-17 stsp got_object_commit_close(commit);
1551 776d4d29 2018-06-17 stsp if (tree)
1552 776d4d29 2018-06-17 stsp got_object_tree_close(tree);
1553 776d4d29 2018-06-17 stsp return err;
1554 68482ea3 2017-11-27 stsp }
1555 07862c20 2018-09-15 stsp
1556 07862c20 2018-09-15 stsp const struct got_error *
1557 07862c20 2018-09-15 stsp got_object_tree_path_changed(int *changed,
1558 07862c20 2018-09-15 stsp struct got_tree_object *tree01, struct got_tree_object *tree02,
1559 07862c20 2018-09-15 stsp const char *path, struct got_repository *repo)
1560 07862c20 2018-09-15 stsp {
1561 07862c20 2018-09-15 stsp const struct got_error *err = NULL;
1562 07862c20 2018-09-15 stsp struct got_tree_object *tree1 = NULL, *tree2 = NULL;
1563 07862c20 2018-09-15 stsp struct got_tree_entry *te1 = NULL, *te2 = NULL;
1564 65a9bbe9 2018-09-15 stsp const char *seg, *s;
1565 3b7f9878 2018-11-18 stsp size_t seglen;
1566 07862c20 2018-09-15 stsp
1567 07862c20 2018-09-15 stsp *changed = 0;
1568 07862c20 2018-09-15 stsp
1569 07862c20 2018-09-15 stsp /* We are expecting an absolute in-repository path. */
1570 07862c20 2018-09-15 stsp if (path[0] != '/')
1571 07862c20 2018-09-15 stsp return got_error(GOT_ERR_NOT_ABSPATH);
1572 07862c20 2018-09-15 stsp
1573 07862c20 2018-09-15 stsp /* We not do support comparing the root path. */
1574 07862c20 2018-09-15 stsp if (path[1] == '\0')
1575 07862c20 2018-09-15 stsp return got_error(GOT_ERR_BAD_PATH);
1576 07862c20 2018-09-15 stsp
1577 07862c20 2018-09-15 stsp tree1 = tree01;
1578 07862c20 2018-09-15 stsp tree2 = tree02;
1579 65a9bbe9 2018-09-15 stsp s = path;
1580 07862c20 2018-09-15 stsp s++; /* skip leading '/' */
1581 07862c20 2018-09-15 stsp seg = s;
1582 65a9bbe9 2018-09-15 stsp seglen = 0;
1583 3b7f9878 2018-11-18 stsp while (*s) {
1584 07862c20 2018-09-15 stsp struct got_tree_object *next_tree1, *next_tree2;
1585 07862c20 2018-09-15 stsp
1586 07862c20 2018-09-15 stsp if (*s != '/') {
1587 07862c20 2018-09-15 stsp s++;
1588 65a9bbe9 2018-09-15 stsp seglen++;
1589 07862c20 2018-09-15 stsp if (*s)
1590 07862c20 2018-09-15 stsp continue;
1591 07862c20 2018-09-15 stsp }
1592 07862c20 2018-09-15 stsp
1593 65a9bbe9 2018-09-15 stsp te1 = find_entry_by_name(tree1, seg, seglen);
1594 07862c20 2018-09-15 stsp if (te1 == NULL) {
1595 07862c20 2018-09-15 stsp err = got_error(GOT_ERR_NO_OBJ);
1596 07862c20 2018-09-15 stsp goto done;
1597 07862c20 2018-09-15 stsp }
1598 07862c20 2018-09-15 stsp
1599 65a9bbe9 2018-09-15 stsp te2 = find_entry_by_name(tree2, seg, seglen);
1600 07862c20 2018-09-15 stsp if (te2 == NULL) {
1601 07862c20 2018-09-15 stsp *changed = 1;
1602 07862c20 2018-09-15 stsp goto done;
1603 07862c20 2018-09-15 stsp }
1604 07862c20 2018-09-15 stsp
1605 07862c20 2018-09-15 stsp if (te1->mode != te2->mode) {
1606 07862c20 2018-09-15 stsp *changed = 1;
1607 07862c20 2018-09-15 stsp goto done;
1608 07862c20 2018-09-15 stsp }
1609 07862c20 2018-09-15 stsp
1610 07862c20 2018-09-15 stsp if (got_object_id_cmp(te1->id, te2->id) == 0) {
1611 07862c20 2018-09-15 stsp *changed = 0;
1612 07862c20 2018-09-15 stsp goto done;
1613 07862c20 2018-09-15 stsp }
1614 07862c20 2018-09-15 stsp
1615 3b7f9878 2018-11-18 stsp if (*s == '\0') { /* final path element */
1616 07862c20 2018-09-15 stsp *changed = 1;
1617 07862c20 2018-09-15 stsp goto done;
1618 07862c20 2018-09-15 stsp }
1619 07862c20 2018-09-15 stsp
1620 07862c20 2018-09-15 stsp seg = s + 1;
1621 07862c20 2018-09-15 stsp s++;
1622 65a9bbe9 2018-09-15 stsp seglen = 0;
1623 07862c20 2018-09-15 stsp if (*s) {
1624 07862c20 2018-09-15 stsp err = got_object_open_as_tree(&next_tree1, repo,
1625 07862c20 2018-09-15 stsp te1->id);
1626 07862c20 2018-09-15 stsp te1 = NULL;
1627 07862c20 2018-09-15 stsp if (err)
1628 07862c20 2018-09-15 stsp goto done;
1629 a31cea73 2018-09-15 stsp if (tree1 != tree01)
1630 a31cea73 2018-09-15 stsp got_object_tree_close(tree1);
1631 07862c20 2018-09-15 stsp tree1 = next_tree1;
1632 07862c20 2018-09-15 stsp
1633 07862c20 2018-09-15 stsp err = got_object_open_as_tree(&next_tree2, repo,
1634 07862c20 2018-09-15 stsp te2->id);
1635 07862c20 2018-09-15 stsp te2 = NULL;
1636 07862c20 2018-09-15 stsp if (err)
1637 07862c20 2018-09-15 stsp goto done;
1638 a31cea73 2018-09-15 stsp if (tree2 != tree02)
1639 a31cea73 2018-09-15 stsp got_object_tree_close(tree2);
1640 07862c20 2018-09-15 stsp tree2 = next_tree2;
1641 07862c20 2018-09-15 stsp }
1642 07862c20 2018-09-15 stsp }
1643 07862c20 2018-09-15 stsp done:
1644 a31cea73 2018-09-15 stsp if (tree1 && tree1 != tree01)
1645 07862c20 2018-09-15 stsp got_object_tree_close(tree1);
1646 a31cea73 2018-09-15 stsp if (tree2 && tree2 != tree02)
1647 07862c20 2018-09-15 stsp got_object_tree_close(tree2);
1648 77880158 2018-11-04 stsp return err;
1649 77880158 2018-11-04 stsp }
1650 ed175427 2019-05-09 stsp
1651 ed175427 2019-05-09 stsp const struct got_error *
1652 ed175427 2019-05-09 stsp got_object_tree_entry_dup(struct got_tree_entry **new_te,
1653 ed175427 2019-05-09 stsp struct got_tree_entry *te)
1654 ed175427 2019-05-09 stsp {
1655 ed175427 2019-05-09 stsp const struct got_error *err = NULL;
1656 ed175427 2019-05-09 stsp
1657 ed175427 2019-05-09 stsp *new_te = calloc(1, sizeof(**new_te));
1658 ed175427 2019-05-09 stsp if (*new_te == NULL)
1659 638f9024 2019-05-13 stsp return got_error_from_errno("calloc");
1660 ed175427 2019-05-09 stsp
1661 ed175427 2019-05-09 stsp (*new_te)->mode = te->mode;
1662 ed175427 2019-05-09 stsp (*new_te)->name = strdup(te->name);
1663 ed175427 2019-05-09 stsp if ((*new_te)->name == NULL) {
1664 638f9024 2019-05-13 stsp err = got_error_from_errno("strdup");
1665 8c4eabf2 2019-05-10 stsp goto done;
1666 ed175427 2019-05-09 stsp }
1667 ed175427 2019-05-09 stsp
1668 ed175427 2019-05-09 stsp (*new_te)->id = got_object_id_dup(te->id);
1669 ed175427 2019-05-09 stsp if ((*new_te)->id == NULL) {
1670 638f9024 2019-05-13 stsp err = got_error_from_errno("got_object_id_dup");
1671 8c4eabf2 2019-05-10 stsp goto done;
1672 3ffe981f 2019-05-10 stsp }
1673 8c4eabf2 2019-05-10 stsp done:
1674 8c4eabf2 2019-05-10 stsp if (err) {
1675 8c4eabf2 2019-05-10 stsp got_object_tree_entry_close(*new_te);
1676 8c4eabf2 2019-05-10 stsp *new_te = NULL;
1677 8c4eabf2 2019-05-10 stsp }
1678 8c4eabf2 2019-05-10 stsp return err;
1679 ed175427 2019-05-09 stsp }