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