xref: /freebsd/stand/libsa/pkgfs.c (revision e67aef419093b08984b8a2de535bc3e4ce13e087)
1ca987d46SWarner Losh /*-
2ca987d46SWarner Losh  * Copyright (c) 2007-2014, Juniper Networks, Inc.
3ca987d46SWarner Losh  * All rights reserved.
4ca987d46SWarner Losh  *
5ca987d46SWarner Losh  * Redistribution and use in source and binary forms, with or without
6ca987d46SWarner Losh  * modification, are permitted provided that the following conditions
7ca987d46SWarner Losh  * are met:
8ca987d46SWarner Losh  * 1. Redistributions of source code must retain the above copyright
9ca987d46SWarner Losh  *    notice, this list of conditions and the following disclaimer.
10ca987d46SWarner Losh  * 2. Redistributions in binary form must reproduce the above copyright
11ca987d46SWarner Losh  *    notice, this list of conditions and the following disclaimer in the
12ca987d46SWarner Losh  *    documentation and/or other materials provided with the distribution.
13ca987d46SWarner Losh  *
14ca987d46SWarner Losh  * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
15ca987d46SWarner Losh  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
16ca987d46SWarner Losh  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
17ca987d46SWarner Losh  * ARE DISCLAIMED.  IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
18ca987d46SWarner Losh  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
19ca987d46SWarner Losh  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
20ca987d46SWarner Losh  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
21ca987d46SWarner Losh  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
22ca987d46SWarner Losh  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
23ca987d46SWarner Losh  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
24ca987d46SWarner Losh  * SUCH DAMAGE.
25ca987d46SWarner Losh  */
26ca987d46SWarner Losh 
27ca987d46SWarner Losh #include "stand.h"
28ca987d46SWarner Losh 
29ca987d46SWarner Losh #include <sys/stat.h>
30ca987d46SWarner Losh #include <sys/stdint.h>
31ca987d46SWarner Losh #include <string.h>
32ca987d46SWarner Losh #include <zlib.h>
33ca987d46SWarner Losh 
34ca987d46SWarner Losh static int   pkg_open(const char *, struct open_file *);
35ca987d46SWarner Losh static int   pkg_close(struct open_file *);
36ca987d46SWarner Losh static int   pkg_read(struct open_file *, void *, size_t, size_t *);
37ca987d46SWarner Losh static off_t pkg_seek(struct open_file *, off_t, int);
38ca987d46SWarner Losh static int   pkg_stat(struct open_file *, struct stat *);
39ca987d46SWarner Losh static int   pkg_readdir(struct open_file *, struct dirent *);
4053f151f9SSimon J. Gerraty static off_t pkg_atol(const char *, unsigned);
41ca987d46SWarner Losh 
42ca987d46SWarner Losh struct fs_ops pkgfs_fsops = {
43e7d045aaSWarner Losh 	.fs_name = "pkg",
44e7d045aaSWarner Losh 	.fo_open = pkg_open,
45e7d045aaSWarner Losh 	.fo_close = pkg_close,
46e7d045aaSWarner Losh 	.fo_read = pkg_read,
47e7d045aaSWarner Losh 	.fo_write = null_write,
48e7d045aaSWarner Losh 	.fo_seek = pkg_seek,
49e7d045aaSWarner Losh 	.fo_stat = pkg_stat,
50e7d045aaSWarner Losh 	.fo_readdir = pkg_readdir,
51ca987d46SWarner Losh };
52ca987d46SWarner Losh 
53ca987d46SWarner Losh #define PKG_BUFSIZE	512
54ed19b7c5SSimon J. Gerraty #define	PKG_MAXCACHESZ	(512 * 1024)
55ca987d46SWarner Losh 
56ca987d46SWarner Losh #define	PKG_FILEEXT	".tgz"
57ca987d46SWarner Losh 
58ca987d46SWarner Losh /*
59ca987d46SWarner Losh  * Layout of POSIX 'ustar' header.
60ca987d46SWarner Losh  */
61ca987d46SWarner Losh struct ustar_hdr {
62ca987d46SWarner Losh 	char	ut_name[100];
63ca987d46SWarner Losh 	char	ut_mode[8];
64ca987d46SWarner Losh 	char	ut_uid[8];
65ca987d46SWarner Losh 	char	ut_gid[8];
66ca987d46SWarner Losh 	char	ut_size[12];
67ca987d46SWarner Losh 	char	ut_mtime[12];
68ca987d46SWarner Losh 	char	ut_checksum[8];
69ca987d46SWarner Losh 	char	ut_typeflag[1];
70ca987d46SWarner Losh 	char	ut_linkname[100];
71ca987d46SWarner Losh 	char	ut_magic[6];		/* For POSIX: "ustar\0" */
72ca987d46SWarner Losh 	char	ut_version[2];		/* For POSIX: "00" */
73ca987d46SWarner Losh 	char	ut_uname[32];
74ca987d46SWarner Losh 	char	ut_gname[32];
75ca987d46SWarner Losh 	char	ut_rdevmajor[8];
76ca987d46SWarner Losh 	char	ut_rdevminor[8];
77ca987d46SWarner Losh 	union {
78ca987d46SWarner Losh 		struct {
79ca987d46SWarner Losh 			char	prefix[155];
80ca987d46SWarner Losh 		} posix;
81ca987d46SWarner Losh 		struct {
82ca987d46SWarner Losh 			char	atime[12];
83ca987d46SWarner Losh 			char	ctime[12];
84ca987d46SWarner Losh 			char	offset[12];
85ca987d46SWarner Losh 			char	longnames[4];
86ca987d46SWarner Losh 			char	unused[1];
87ca987d46SWarner Losh 			struct gnu_sparse {
88ca987d46SWarner Losh 				char	offset[12];
89ca987d46SWarner Losh 				char	numbytes[12];
90ca987d46SWarner Losh 			} sparse[4];
91ca987d46SWarner Losh 			char	isextended[1];
92ca987d46SWarner Losh 			char	realsize[12];
93ca987d46SWarner Losh 		} gnu;
94ca987d46SWarner Losh 	} u;
95ca987d46SWarner Losh 	u_char __padding[12];
96ca987d46SWarner Losh };
97ca987d46SWarner Losh 
98ca987d46SWarner Losh struct package;
99ca987d46SWarner Losh 
100ca987d46SWarner Losh struct tarfile
101ca987d46SWarner Losh {
102ca987d46SWarner Losh 	struct package *tf_pkg;
103ca987d46SWarner Losh 	struct tarfile *tf_next;
104ca987d46SWarner Losh 	struct ustar_hdr tf_hdr;
105ca987d46SWarner Losh 	off_t	tf_ofs;
106ca987d46SWarner Losh 	off_t	tf_size;
107ca987d46SWarner Losh 	off_t	tf_fp;
108ca987d46SWarner Losh 	size_t	tf_cachesz;
109ca987d46SWarner Losh 	void	*tf_cache;
110ca987d46SWarner Losh };
111ca987d46SWarner Losh 
112ca987d46SWarner Losh struct package
113ca987d46SWarner Losh {
114ca987d46SWarner Losh 	struct package *pkg_chain;
115ca987d46SWarner Losh 	int	pkg_fd;
116ca987d46SWarner Losh 	off_t	pkg_ofs;
117ca987d46SWarner Losh 	z_stream pkg_zs;
118ca987d46SWarner Losh 	struct tarfile *pkg_first;
119ca987d46SWarner Losh 	struct tarfile *pkg_last;
120ca987d46SWarner Losh 	u_char	pkg_buf[PKG_BUFSIZE];
121ca987d46SWarner Losh };
122ca987d46SWarner Losh 
123ca987d46SWarner Losh static struct package *package = NULL;
124ca987d46SWarner Losh 
125ca987d46SWarner Losh static int new_package(int, struct package **);
126723f9041SSimon J. Gerraty static int cache_data(struct tarfile *tf, int);
127ca987d46SWarner Losh 
128ca987d46SWarner Losh void
pkgfs_cleanup(void)129ca987d46SWarner Losh pkgfs_cleanup(void)
130ca987d46SWarner Losh {
131ca987d46SWarner Losh 	struct package *chain;
132ca987d46SWarner Losh 	struct tarfile *tf, *tfn;
133ca987d46SWarner Losh 
134ca987d46SWarner Losh 	while (package != NULL) {
135ca987d46SWarner Losh 		inflateEnd(&package->pkg_zs);
136ca987d46SWarner Losh 		close(package->pkg_fd);
137ca987d46SWarner Losh 
138ca987d46SWarner Losh 		tf = package->pkg_first;
139ca987d46SWarner Losh 		while (tf != NULL) {
140ca987d46SWarner Losh 			tfn = tf->tf_next;
141ca987d46SWarner Losh 			if (tf->tf_cachesz > 0)
142ca987d46SWarner Losh 				free(tf->tf_cache);
143ca987d46SWarner Losh 			free(tf);
144ca987d46SWarner Losh 			tf = tfn;
145ca987d46SWarner Losh 		}
146ca987d46SWarner Losh 
147ca987d46SWarner Losh 		chain = package->pkg_chain;
148ca987d46SWarner Losh 		free(package);
149ca987d46SWarner Losh 		package = chain;
150ca987d46SWarner Losh 	}
151ca987d46SWarner Losh }
152ca987d46SWarner Losh 
153ca987d46SWarner Losh int
pkgfs_init(const char * pkgname,struct fs_ops * proto)154ca987d46SWarner Losh pkgfs_init(const char *pkgname, struct fs_ops *proto)
155ca987d46SWarner Losh {
156ca987d46SWarner Losh 	struct package *pkg;
157ca987d46SWarner Losh 	int error, fd;
158ca987d46SWarner Losh 
15999a9cf51SKyle Evans 	pkg = NULL;
160ca987d46SWarner Losh 	if (proto != &pkgfs_fsops)
161ca987d46SWarner Losh 		pkgfs_cleanup();
162ca987d46SWarner Losh 
163ca987d46SWarner Losh 	exclusive_file_system = proto;
164ca987d46SWarner Losh 
165ca987d46SWarner Losh 	fd = open(pkgname, O_RDONLY);
166ca987d46SWarner Losh 
167ca987d46SWarner Losh 	exclusive_file_system = NULL;
168ca987d46SWarner Losh 
169*e67aef41SSimon J. Gerraty 	DEBUG_PRINTF(0, ("%s(%s: '%s') -> %d (error=%d)\n", __func__,
170*e67aef41SSimon J. Gerraty 		proto->fs_name, pkgname, fd, errno));
171*e67aef41SSimon J. Gerraty 
172ca987d46SWarner Losh 	if (fd == -1)
173ca987d46SWarner Losh 		return (errno);
174ca987d46SWarner Losh 
175ca987d46SWarner Losh 	error = new_package(fd, &pkg);
176ca987d46SWarner Losh 	if (error) {
177ca987d46SWarner Losh 		close(fd);
178ca987d46SWarner Losh 		return (error);
179ca987d46SWarner Losh 	}
180ca987d46SWarner Losh 
181ca987d46SWarner Losh 	if (pkg == NULL)
182ca987d46SWarner Losh 		return (EDOOFUS);
183ca987d46SWarner Losh 
184ca987d46SWarner Losh 	pkg->pkg_chain = package;
185ca987d46SWarner Losh 	package = pkg;
186ca987d46SWarner Losh 	exclusive_file_system = &pkgfs_fsops;
187ca987d46SWarner Losh 	return (0);
188ca987d46SWarner Losh }
189ca987d46SWarner Losh 
190ca987d46SWarner Losh static int get_mode(struct tarfile *);
191ca987d46SWarner Losh static int get_zipped(struct package *, void *, size_t);
192ca987d46SWarner Losh static int new_package(int, struct package **);
193ca987d46SWarner Losh static struct tarfile *scan_tarfile(struct package *, struct tarfile *);
194ca987d46SWarner Losh 
195ca987d46SWarner Losh static int
pkg_open_follow(const char * fn,struct open_file * f,int lnks)196b14cfecbSSimon J. Gerraty pkg_open_follow(const char *fn, struct open_file *f, int lnks)
197ca987d46SWarner Losh {
198ca987d46SWarner Losh 	struct tarfile *tf;
199ca987d46SWarner Losh 
200ca987d46SWarner Losh 	if (fn == NULL || f == NULL)
201ca987d46SWarner Losh 		return (EINVAL);
202ca987d46SWarner Losh 
203ca987d46SWarner Losh 	if (package == NULL)
204ca987d46SWarner Losh 		return (ENXIO);
205ca987d46SWarner Losh 
206ca987d46SWarner Losh 	/*
207ca987d46SWarner Losh 	 * We can only read from a package, so reject request to open
208ca987d46SWarner Losh 	 * for write-only or read-write.
209ca987d46SWarner Losh 	 */
210ca987d46SWarner Losh 	if (f->f_flags != F_READ)
211ca987d46SWarner Losh 		return (EPERM);
212ca987d46SWarner Losh 
213ca987d46SWarner Losh 	/*
214ca987d46SWarner Losh 	 * Scan the file headers for the named file. We stop scanning
215ca987d46SWarner Losh 	 * at the first filename that has the .pkg extension. This is
216ca987d46SWarner Losh 	 * a package within a package. We assume we have all the files
217ca987d46SWarner Losh 	 * we need up-front and without having to dig within nested
218ca987d46SWarner Losh 	 * packages.
219ca987d46SWarner Losh 	 *
220ca987d46SWarner Losh 	 * Note that we preserve streaming properties as much as possible.
221ca987d46SWarner Losh 	 */
222ca987d46SWarner Losh 	while (*fn == '/')
223ca987d46SWarner Losh 		fn++;
224ca987d46SWarner Losh 
225ca987d46SWarner Losh 	/*
226ca987d46SWarner Losh 	 * Allow opening of the root directory for use by readdir()
227ca987d46SWarner Losh 	 * to support listing files in the package.
228ca987d46SWarner Losh 	 */
229ca987d46SWarner Losh 	if (*fn == '\0') {
230ca987d46SWarner Losh 		f->f_fsdata = NULL;
231ca987d46SWarner Losh 		return (0);
232ca987d46SWarner Losh 	}
233ca987d46SWarner Losh 
234ca987d46SWarner Losh 	tf = scan_tarfile(package, NULL);
235ca987d46SWarner Losh 	while (tf != NULL) {
236ca987d46SWarner Losh 		if (strcmp(fn, tf->tf_hdr.ut_name) == 0) {
237ca987d46SWarner Losh 			f->f_fsdata = tf;
238ca987d46SWarner Losh 			tf->tf_fp = 0;	/* Reset the file pointer. */
239*e67aef41SSimon J. Gerraty 			DEBUG_PRINTF(1, ("%s: found %s type %c\n", __func__,
240b14cfecbSSimon J. Gerraty 			     fn, tf->tf_hdr.ut_typeflag[0]));
241b14cfecbSSimon J. Gerraty 			if (tf->tf_hdr.ut_typeflag[0] == '2') {
242b14cfecbSSimon J. Gerraty 			    /* we have a symlink
243b14cfecbSSimon J. Gerraty 			     * Note: ut_linkname is only 100 chars!
244b14cfecbSSimon J. Gerraty 			     */
245b14cfecbSSimon J. Gerraty 			    if (lnks++ >= 8)
246b14cfecbSSimon J. Gerraty 				return (EMLINK);
247b14cfecbSSimon J. Gerraty 			    return pkg_open_follow(tf->tf_hdr.ut_linkname,
248b14cfecbSSimon J. Gerraty 				f, lnks);
249b14cfecbSSimon J. Gerraty 			}
250ca987d46SWarner Losh 			return (0);
251ca987d46SWarner Losh 		}
252ca987d46SWarner Losh 		tf = scan_tarfile(package, tf);
253ca987d46SWarner Losh 	}
254ca987d46SWarner Losh 	return (errno);
255ca987d46SWarner Losh }
256ca987d46SWarner Losh 
257ca987d46SWarner Losh static int
pkg_open(const char * fn,struct open_file * f)258b14cfecbSSimon J. Gerraty pkg_open(const char *fn, struct open_file *f)
259b14cfecbSSimon J. Gerraty {
260b14cfecbSSimon J. Gerraty     return pkg_open_follow(fn, f, 0);
261b14cfecbSSimon J. Gerraty }
262b14cfecbSSimon J. Gerraty 
263b14cfecbSSimon J. Gerraty static int
pkg_close(struct open_file * f)264ca987d46SWarner Losh pkg_close(struct open_file *f)
265ca987d46SWarner Losh {
266ca987d46SWarner Losh 	struct tarfile *tf;
267ca987d46SWarner Losh 
268ca987d46SWarner Losh 	tf = (struct tarfile *)f->f_fsdata;
269ca987d46SWarner Losh 	if (tf == NULL)
270ca987d46SWarner Losh 		return (0);
271ca987d46SWarner Losh 
272ca987d46SWarner Losh 	/*
273ca987d46SWarner Losh 	 * Free up the cache if we read all of the file.
274ca987d46SWarner Losh 	 */
275*e67aef41SSimon J. Gerraty 	DEBUG_PRINTF(1, ("%s(%s)\n", __func__, tf->tf_hdr.ut_name));
276ca987d46SWarner Losh 	if (tf->tf_fp == tf->tf_size && tf->tf_cachesz > 0) {
277ca987d46SWarner Losh 		free(tf->tf_cache);
278ca987d46SWarner Losh 		tf->tf_cachesz = 0;
279ca987d46SWarner Losh 	}
280ca987d46SWarner Losh 	return (0);
281ca987d46SWarner Losh }
282ca987d46SWarner Losh 
283ca987d46SWarner Losh static int
pkg_read(struct open_file * f,void * buf,size_t size,size_t * res)284ca987d46SWarner Losh pkg_read(struct open_file *f, void *buf, size_t size, size_t *res)
285ca987d46SWarner Losh {
286ca987d46SWarner Losh 	struct tarfile *tf;
287ca987d46SWarner Losh 	char *p;
288ca987d46SWarner Losh 	off_t fp;
289ca987d46SWarner Losh 	size_t sz;
290ca987d46SWarner Losh 
291ca987d46SWarner Losh 	tf = (struct tarfile *)f->f_fsdata;
292ca987d46SWarner Losh 	if (tf == NULL) {
293ca987d46SWarner Losh 		if (res != NULL)
294ca987d46SWarner Losh 			*res = size;
295ca987d46SWarner Losh 		return (EBADF);
296ca987d46SWarner Losh 	}
297ca987d46SWarner Losh 
298*e67aef41SSimon J. Gerraty 	DEBUG_PRINTF(4, ("%s(%s,%zd)\n", __func__, tf->tf_hdr.ut_name, size));
299*e67aef41SSimon J. Gerraty 
300723f9041SSimon J. Gerraty 	if (tf->tf_cachesz == 0)
301723f9041SSimon J. Gerraty 		cache_data(tf, 1);
302723f9041SSimon J. Gerraty 
303ca987d46SWarner Losh 	fp = tf->tf_fp;
304ca987d46SWarner Losh 	p = buf;
305ca987d46SWarner Losh 	sz = 0;
306ca987d46SWarner Losh 	while (size > 0) {
307ca987d46SWarner Losh 		sz = tf->tf_size - fp;
308ca987d46SWarner Losh 		if (fp < tf->tf_cachesz && tf->tf_cachesz < tf->tf_size)
309ca987d46SWarner Losh 			sz = tf->tf_cachesz - fp;
310ca987d46SWarner Losh 		if (size < sz)
311ca987d46SWarner Losh 			sz = size;
312ca987d46SWarner Losh 		if (sz == 0)
313ca987d46SWarner Losh 			break;
314ca987d46SWarner Losh 
315ca987d46SWarner Losh 		if (fp < tf->tf_cachesz) {
316ca987d46SWarner Losh 			/* Satisfy the request from cache. */
317ca987d46SWarner Losh 			memcpy(p, tf->tf_cache + fp, sz);
318ca987d46SWarner Losh 			fp += sz;
319ca987d46SWarner Losh 			p += sz;
320ca987d46SWarner Losh 			size -= sz;
321ca987d46SWarner Losh 			continue;
322ca987d46SWarner Losh 		}
323ca987d46SWarner Losh 
324ca987d46SWarner Losh 		if (get_zipped(tf->tf_pkg, p, sz) == -1) {
325ca987d46SWarner Losh 			sz = -1;
326ca987d46SWarner Losh 			break;
327ca987d46SWarner Losh 		}
328ca987d46SWarner Losh 
329ca987d46SWarner Losh 		fp += sz;
330ca987d46SWarner Losh 		p += sz;
331ca987d46SWarner Losh 		size -= sz;
332ca987d46SWarner Losh 	}
333ca987d46SWarner Losh 
334ca987d46SWarner Losh 	tf->tf_fp = fp;
335ca987d46SWarner Losh 	if (res != NULL)
336ca987d46SWarner Losh 		*res = size;
337*e67aef41SSimon J. Gerraty 	DEBUG_PRINTF(4, ("%s(%s) res=%zd\n", __func__, tf->tf_hdr.ut_name,
338*e67aef41SSimon J. Gerraty 	     (ssize_t)(tf->tf_size - tf->tf_fp)));
339ca987d46SWarner Losh 	return ((sz == -1) ? errno : 0);
340ca987d46SWarner Losh }
341ca987d46SWarner Losh 
342ca987d46SWarner Losh static off_t
pkg_seek(struct open_file * f,off_t ofs,int whence)343ca987d46SWarner Losh pkg_seek(struct open_file *f, off_t ofs, int whence)
344ca987d46SWarner Losh {
345ca987d46SWarner Losh 	char buf[512];
346ca987d46SWarner Losh 	struct tarfile *tf;
347ca987d46SWarner Losh 	off_t delta;
34853f151f9SSimon J. Gerraty 	off_t nofs;
349ca987d46SWarner Losh 	size_t sz, res;
350ca987d46SWarner Losh 	int error;
351ca987d46SWarner Losh 
352ca987d46SWarner Losh 	tf = (struct tarfile *)f->f_fsdata;
353ca987d46SWarner Losh 	if (tf == NULL) {
354ca987d46SWarner Losh 		errno = EBADF;
355ca987d46SWarner Losh 		return (-1);
356ca987d46SWarner Losh 	}
357ca987d46SWarner Losh 
358ca987d46SWarner Losh 	switch (whence) {
359ca987d46SWarner Losh 	case SEEK_SET:
360ca987d46SWarner Losh 		delta = ofs - tf->tf_fp;
361ca987d46SWarner Losh 		break;
362ca987d46SWarner Losh 	case SEEK_CUR:
363ca987d46SWarner Losh 		delta = ofs;
364ca987d46SWarner Losh 		break;
365ca987d46SWarner Losh 	case SEEK_END:
366ca987d46SWarner Losh 		delta = tf->tf_size - tf->tf_fp + ofs;
367ca987d46SWarner Losh 		break;
368ca987d46SWarner Losh 	default:
369ca987d46SWarner Losh 		errno = EINVAL;
370ca987d46SWarner Losh 		return (-1);
371ca987d46SWarner Losh 	}
372ca987d46SWarner Losh 
373ca987d46SWarner Losh 	if (delta < 0) {
37453f151f9SSimon J. Gerraty 		/* seeking backwards - ok if within cache */
37553f151f9SSimon J. Gerraty 		if (tf->tf_cachesz > 0 && tf->tf_fp <= tf->tf_cachesz) {
37653f151f9SSimon J. Gerraty 			nofs = tf->tf_fp + delta;
37753f151f9SSimon J. Gerraty 			if (nofs >= 0) {
37853f151f9SSimon J. Gerraty 				tf->tf_fp = nofs;
37953f151f9SSimon J. Gerraty 				return (tf->tf_fp);
38053f151f9SSimon J. Gerraty 			}
38153f151f9SSimon J. Gerraty 		}
382*e67aef41SSimon J. Gerraty 		DEBUG_PRINTF(3, ("%s: negative file seek (%jd)\n", __func__,
383ca987d46SWarner Losh 		    (intmax_t)delta));
384ca987d46SWarner Losh 		errno = ESPIPE;
385ca987d46SWarner Losh 		return (-1);
386ca987d46SWarner Losh 	}
387ca987d46SWarner Losh 
388ca987d46SWarner Losh 	while (delta > 0 && tf->tf_fp < tf->tf_size) {
389ca987d46SWarner Losh 		sz = (delta > sizeof(buf)) ? sizeof(buf) : delta;
390ca987d46SWarner Losh 		error = pkg_read(f, buf, sz, &res);
391ca987d46SWarner Losh 		if (error != 0) {
392ca987d46SWarner Losh 			errno = error;
393ca987d46SWarner Losh 			return (-1);
394ca987d46SWarner Losh 		}
395ca987d46SWarner Losh 		delta -= sz - res;
396ca987d46SWarner Losh 	}
397ca987d46SWarner Losh 
398ca987d46SWarner Losh 	return (tf->tf_fp);
399ca987d46SWarner Losh }
400ca987d46SWarner Losh 
401ca987d46SWarner Losh static int
pkg_stat(struct open_file * f,struct stat * sb)402ca987d46SWarner Losh pkg_stat(struct open_file *f, struct stat *sb)
403ca987d46SWarner Losh {
404ca987d46SWarner Losh 	struct tarfile *tf;
405ca987d46SWarner Losh 
406ca987d46SWarner Losh 	tf = (struct tarfile *)f->f_fsdata;
407ca987d46SWarner Losh 	if (tf == NULL)
408ca987d46SWarner Losh 		return (EBADF);
409ca987d46SWarner Losh 	memset(sb, 0, sizeof(*sb));
410ca987d46SWarner Losh 	sb->st_mode = get_mode(tf);
41153f151f9SSimon J. Gerraty 	if ((sb->st_mode & S_IFMT) == 0) {
41253f151f9SSimon J. Gerraty 		/* tar file bug - assume regular file */
41353f151f9SSimon J. Gerraty 		sb->st_mode |= S_IFREG;
41453f151f9SSimon J. Gerraty 	}
415ca987d46SWarner Losh 	sb->st_size = tf->tf_size;
416ca987d46SWarner Losh 	sb->st_blocks = (tf->tf_size + 511) / 512;
41753f151f9SSimon J. Gerraty 	sb->st_mtime = pkg_atol(tf->tf_hdr.ut_mtime, 12);
4186c88ef1cSAdrian Chadd 	sb->st_dev = (off_t)((uintptr_t)tf->tf_pkg);
41953f151f9SSimon J. Gerraty 	sb->st_ino = tf->tf_ofs;	/* unique per tf_pkg */
420ca987d46SWarner Losh 	return (0);
421ca987d46SWarner Losh }
422ca987d46SWarner Losh 
423ca987d46SWarner Losh static int
pkg_readdir(struct open_file * f,struct dirent * d)424ca987d46SWarner Losh pkg_readdir(struct open_file *f, struct dirent *d)
425ca987d46SWarner Losh {
426ca987d46SWarner Losh 	struct tarfile *tf;
427ca987d46SWarner Losh 
428ca987d46SWarner Losh 	tf = (struct tarfile *)f->f_fsdata;
429ca987d46SWarner Losh 	if (tf != NULL)
430ca987d46SWarner Losh 		return (EBADF);
431ca987d46SWarner Losh 
432ca987d46SWarner Losh 	tf = scan_tarfile(package, NULL);
433ca987d46SWarner Losh 	if (tf == NULL)
434ca987d46SWarner Losh 		return (ENOENT);
435ca987d46SWarner Losh 
436ca987d46SWarner Losh 	d->d_fileno = 0;
437ca987d46SWarner Losh 	d->d_reclen = sizeof(*d);
438ca987d46SWarner Losh 	d->d_type = DT_REG;
439ca987d46SWarner Losh 	memcpy(d->d_name, tf->tf_hdr.ut_name, sizeof(d->d_name));
440ca987d46SWarner Losh 	return (0);
441ca987d46SWarner Losh }
442ca987d46SWarner Losh 
443ca987d46SWarner Losh /*
444ca987d46SWarner Losh  * Low-level support functions.
445ca987d46SWarner Losh  */
446ca987d46SWarner Losh 
447ca987d46SWarner Losh static int
get_byte(struct package * pkg,off_t * op)448ca987d46SWarner Losh get_byte(struct package *pkg, off_t *op)
449ca987d46SWarner Losh {
450ca987d46SWarner Losh 	int c;
451ca987d46SWarner Losh 
452ca987d46SWarner Losh 	if (pkg->pkg_zs.avail_in == 0) {
453ca987d46SWarner Losh 		c = read(pkg->pkg_fd, pkg->pkg_buf, PKG_BUFSIZE);
454ca987d46SWarner Losh 		if (c <= 0)
455ca987d46SWarner Losh 			return (-1);
456ca987d46SWarner Losh 		pkg->pkg_zs.avail_in = c;
457ca987d46SWarner Losh 		pkg->pkg_zs.next_in = pkg->pkg_buf;
458ca987d46SWarner Losh 	}
459ca987d46SWarner Losh 
460ca987d46SWarner Losh 	c = *pkg->pkg_zs.next_in;
461ca987d46SWarner Losh 	pkg->pkg_zs.next_in++;
462ca987d46SWarner Losh 	pkg->pkg_zs.avail_in--;
463ca987d46SWarner Losh 	(*op)++;
464ca987d46SWarner Losh 	return (c);
465ca987d46SWarner Losh }
466ca987d46SWarner Losh 
467ca987d46SWarner Losh static int
get_zipped(struct package * pkg,void * buf,size_t bufsz)468ca987d46SWarner Losh get_zipped(struct package *pkg, void *buf, size_t bufsz)
469ca987d46SWarner Losh {
470ca987d46SWarner Losh 	int c;
471ca987d46SWarner Losh 
472ca987d46SWarner Losh 	pkg->pkg_zs.next_out = buf;
473ca987d46SWarner Losh 	pkg->pkg_zs.avail_out = bufsz;
474ca987d46SWarner Losh 
475ca987d46SWarner Losh 	while (pkg->pkg_zs.avail_out) {
476ca987d46SWarner Losh 		if (pkg->pkg_zs.avail_in == 0) {
477ca987d46SWarner Losh 			c = read(pkg->pkg_fd, pkg->pkg_buf, PKG_BUFSIZE);
478ca987d46SWarner Losh 			if (c <= 0) {
479ca987d46SWarner Losh 				errno = EIO;
480ca987d46SWarner Losh 				return (-1);
481ca987d46SWarner Losh 			}
482ca987d46SWarner Losh 			pkg->pkg_zs.avail_in = c;
483ca987d46SWarner Losh 			pkg->pkg_zs.next_in = pkg->pkg_buf;
484ca987d46SWarner Losh 		}
485ca987d46SWarner Losh 
486ca987d46SWarner Losh 		c = inflate(&pkg->pkg_zs, Z_SYNC_FLUSH);
487ca987d46SWarner Losh 		if (c != Z_OK && c != Z_STREAM_END) {
488ca987d46SWarner Losh 			errno = EIO;
489ca987d46SWarner Losh 			return (-1);
490ca987d46SWarner Losh 		}
491ca987d46SWarner Losh 	}
492ca987d46SWarner Losh 
493ca987d46SWarner Losh 	pkg->pkg_ofs += bufsz;
494ca987d46SWarner Losh 	return (0);
495ca987d46SWarner Losh }
496ca987d46SWarner Losh 
497723f9041SSimon J. Gerraty /**
498723f9041SSimon J. Gerraty  * @brief
499723f9041SSimon J. Gerraty  * cache data of a tarfile
500723f9041SSimon J. Gerraty  *
501723f9041SSimon J. Gerraty  * @param[in] tf
502723f9041SSimon J. Gerraty  *	tarfile pointer
503723f9041SSimon J. Gerraty  *
504723f9041SSimon J. Gerraty  * @param[in] force
505723f9041SSimon J. Gerraty  *	If file size > PKG_MAXCACHESZ, cache that much
506723f9041SSimon J. Gerraty  *
507723f9041SSimon J. Gerraty  * @return 0, -1 (errno set to error value)
508723f9041SSimon J. Gerraty  */
509ca987d46SWarner Losh static int
cache_data(struct tarfile * tf,int force)510723f9041SSimon J. Gerraty cache_data(struct tarfile *tf, int force)
511ca987d46SWarner Losh {
512ca987d46SWarner Losh 	struct package *pkg;
513ca987d46SWarner Losh 	size_t sz;
514ca987d46SWarner Losh 
515ca987d46SWarner Losh 	if (tf == NULL) {
516*e67aef41SSimon J. Gerraty 		DEBUG_PRINTF(5, ("%s: no file to cache data for?\n",
517*e67aef41SSimon J. Gerraty 			__func__));
518ca987d46SWarner Losh 		errno = EINVAL;
519ca987d46SWarner Losh 		return (-1);
520ca987d46SWarner Losh 	}
521ca987d46SWarner Losh 
522ca987d46SWarner Losh 	pkg = tf->tf_pkg;
523ca987d46SWarner Losh 	if (pkg == NULL) {
524*e67aef41SSimon J. Gerraty 		DEBUG_PRINTF(5, ("%s: no package associated with file?\n",
525*e67aef41SSimon J. Gerraty 			__func__));
526ca987d46SWarner Losh 		errno = EINVAL;
527ca987d46SWarner Losh 		return (-1);
528ca987d46SWarner Losh 	}
529ca987d46SWarner Losh 
530723f9041SSimon J. Gerraty 	if (tf->tf_cachesz > 0) {
531*e67aef41SSimon J. Gerraty 		DEBUG_PRINTF(5, ("%s: data already cached\n", __func__));
532723f9041SSimon J. Gerraty 		errno = EINVAL;
533723f9041SSimon J. Gerraty 		return (-1);
534723f9041SSimon J. Gerraty 	}
535723f9041SSimon J. Gerraty 
536ca987d46SWarner Losh 	if (tf->tf_ofs != pkg->pkg_ofs) {
537*e67aef41SSimon J. Gerraty 		DEBUG_PRINTF(5, ("%s: caching after force read of file %s?\n",
538ca987d46SWarner Losh 		    __func__, tf->tf_hdr.ut_name));
539ca987d46SWarner Losh 		errno = EINVAL;
540ca987d46SWarner Losh 		return (-1);
541ca987d46SWarner Losh 	}
542ca987d46SWarner Losh 
543ca987d46SWarner Losh 	/* We don't cache everything... */
544723f9041SSimon J. Gerraty 	if (tf->tf_size > PKG_MAXCACHESZ && !force)  {
545723f9041SSimon J. Gerraty 		errno = ENOBUFS;
546ca987d46SWarner Losh 		return (-1);
547ca987d46SWarner Losh 	}
548ca987d46SWarner Losh 
549723f9041SSimon J. Gerraty 	sz = tf->tf_size < PKG_MAXCACHESZ ? tf->tf_size : PKG_MAXCACHESZ;
550ca987d46SWarner Losh 	/* All files are padded to a multiple of 512 bytes. */
551723f9041SSimon J. Gerraty 	sz = (sz + 0x1ff) & ~0x1ff;
552ca987d46SWarner Losh 
553ca987d46SWarner Losh 	tf->tf_cache = malloc(sz);
554ca987d46SWarner Losh 	if (tf->tf_cache == NULL) {
555*e67aef41SSimon J. Gerraty 		DEBUG_PRINTF(5, ("%s: could not allocate %d bytes\n",
556*e67aef41SSimon J. Gerraty 			__func__, (int)sz));
557ca987d46SWarner Losh 		errno = ENOMEM;
558ca987d46SWarner Losh 		return (-1);
559ca987d46SWarner Losh 	}
560ca987d46SWarner Losh 
561ca987d46SWarner Losh 	tf->tf_cachesz = sz;
562ca987d46SWarner Losh 	return (get_zipped(pkg, tf->tf_cache, sz));
563ca987d46SWarner Losh }
564ca987d46SWarner Losh 
565ca987d46SWarner Losh /*
566ca987d46SWarner Losh  * Note that this implementation does not (and should not!) obey
567ca987d46SWarner Losh  * locale settings; you cannot simply substitute strtol here, since
568ca987d46SWarner Losh  * it does obey locale.
569ca987d46SWarner Losh  */
570ca987d46SWarner Losh static off_t
pkg_atol8(const char * p,unsigned char_cnt)571ca987d46SWarner Losh pkg_atol8(const char *p, unsigned char_cnt)
572ca987d46SWarner Losh {
573ca987d46SWarner Losh         int64_t l, limit, last_digit_limit;
574ca987d46SWarner Losh         int digit, sign, base;
575ca987d46SWarner Losh 
576ca987d46SWarner Losh         base = 8;
577ca987d46SWarner Losh         limit = INT64_MAX / base;
578ca987d46SWarner Losh         last_digit_limit = INT64_MAX % base;
579ca987d46SWarner Losh 
580ca987d46SWarner Losh         while (*p == ' ' || *p == '\t')
581ca987d46SWarner Losh                 p++;
582ca987d46SWarner Losh         if (*p == '-') {
583ca987d46SWarner Losh                 sign = -1;
584ca987d46SWarner Losh                 p++;
585ca987d46SWarner Losh         } else
586ca987d46SWarner Losh                 sign = 1;
587ca987d46SWarner Losh 
588ca987d46SWarner Losh         l = 0;
589ca987d46SWarner Losh         digit = *p - '0';
590ca987d46SWarner Losh         while (digit >= 0 && digit < base  && char_cnt-- > 0) {
591ca987d46SWarner Losh                 if (l>limit || (l == limit && digit > last_digit_limit)) {
592ca987d46SWarner Losh                         l = UINT64_MAX; /* Truncate on overflow. */
593ca987d46SWarner Losh                         break;
594ca987d46SWarner Losh                 }
595ca987d46SWarner Losh                 l = (l * base) + digit;
596ca987d46SWarner Losh                 digit = *++p - '0';
597ca987d46SWarner Losh         }
598ca987d46SWarner Losh         return (sign < 0) ? -l : l;
599ca987d46SWarner Losh }
600ca987d46SWarner Losh 
601ca987d46SWarner Losh /*
602ca987d46SWarner Losh  * Parse a base-256 integer.  This is just a straight signed binary
603ca987d46SWarner Losh  * value in big-endian order, except that the high-order bit is
604ca987d46SWarner Losh  * ignored.  Remember that "int64_t" may or may not be exactly 64
605ca987d46SWarner Losh  * bits; the implementation here tries to avoid making any assumptions
606ca987d46SWarner Losh  * about the actual size of an int64_t.  It does assume we're using
607ca987d46SWarner Losh  * twos-complement arithmetic, though.
608ca987d46SWarner Losh  */
609ca987d46SWarner Losh static int64_t
pkg_atol256(const char * _p,unsigned char_cnt)610ca987d46SWarner Losh pkg_atol256(const char *_p, unsigned char_cnt)
611ca987d46SWarner Losh {
612ca987d46SWarner Losh         int64_t l, upper_limit, lower_limit;
613ca987d46SWarner Losh         const unsigned char *p = (const unsigned char *)_p;
614ca987d46SWarner Losh 
615ca987d46SWarner Losh         upper_limit = INT64_MAX / 256;
616ca987d46SWarner Losh         lower_limit = INT64_MIN / 256;
617ca987d46SWarner Losh 
618ca987d46SWarner Losh         /* Pad with 1 or 0 bits, depending on sign. */
619ca987d46SWarner Losh         if ((0x40 & *p) == 0x40)
620ca987d46SWarner Losh                 l = (int64_t)-1;
621ca987d46SWarner Losh         else
622ca987d46SWarner Losh                 l = 0;
623ca987d46SWarner Losh         l = (l << 6) | (0x3f & *p++);
624ca987d46SWarner Losh         while (--char_cnt > 0) {
625ca987d46SWarner Losh                 if (l > upper_limit) {
626ca987d46SWarner Losh                         l = INT64_MAX; /* Truncate on overflow */
627ca987d46SWarner Losh                         break;
628ca987d46SWarner Losh                 } else if (l < lower_limit) {
629ca987d46SWarner Losh                         l = INT64_MIN;
630ca987d46SWarner Losh                         break;
631ca987d46SWarner Losh                 }
632ca987d46SWarner Losh                 l = (l << 8) | (0xff & (int64_t)*p++);
633ca987d46SWarner Losh         }
634ca987d46SWarner Losh         return (l);
635ca987d46SWarner Losh }
636ca987d46SWarner Losh 
637ca987d46SWarner Losh static off_t
pkg_atol(const char * p,unsigned char_cnt)638ca987d46SWarner Losh pkg_atol(const char *p, unsigned char_cnt)
639ca987d46SWarner Losh {
640ca987d46SWarner Losh 	/*
641ca987d46SWarner Losh 	 * Technically, GNU pkg considers a field to be in base-256
642ca987d46SWarner Losh 	 * only if the first byte is 0xff or 0x80.
643ca987d46SWarner Losh 	 */
644ca987d46SWarner Losh 	if (*p & 0x80)
645ca987d46SWarner Losh 		return (pkg_atol256(p, char_cnt));
646ca987d46SWarner Losh 	return (pkg_atol8(p, char_cnt));
647ca987d46SWarner Losh }
648ca987d46SWarner Losh 
649ca987d46SWarner Losh static int
get_mode(struct tarfile * tf)650ca987d46SWarner Losh get_mode(struct tarfile *tf)
651ca987d46SWarner Losh {
652ca987d46SWarner Losh 	return (pkg_atol(tf->tf_hdr.ut_mode, sizeof(tf->tf_hdr.ut_mode)));
653ca987d46SWarner Losh }
654ca987d46SWarner Losh 
655ca987d46SWarner Losh /* GZip flag byte */
656ca987d46SWarner Losh #define ASCII_FLAG	0x01 /* bit 0 set: file probably ascii text */
657ca987d46SWarner Losh #define HEAD_CRC	0x02 /* bit 1 set: header CRC present */
658ca987d46SWarner Losh #define EXTRA_FIELD	0x04 /* bit 2 set: extra field present */
659ca987d46SWarner Losh #define ORIG_NAME	0x08 /* bit 3 set: original file name present */
660ca987d46SWarner Losh #define COMMENT		0x10 /* bit 4 set: file comment present */
661ca987d46SWarner Losh #define RESERVED	0xE0 /* bits 5..7: reserved */
662ca987d46SWarner Losh 
663ca987d46SWarner Losh static int
new_package(int fd,struct package ** pp)664ca987d46SWarner Losh new_package(int fd, struct package **pp)
665ca987d46SWarner Losh {
666ca987d46SWarner Losh 	struct package *pkg;
667ca987d46SWarner Losh 	off_t ofs;
668ca987d46SWarner Losh 	int flags, i, error;
669ca987d46SWarner Losh 
670ca987d46SWarner Losh 	pkg = malloc(sizeof(*pkg));
671ca987d46SWarner Losh 	if (pkg == NULL)
672ca987d46SWarner Losh 		return (ENOMEM);
673ca987d46SWarner Losh 
674ca987d46SWarner Losh 	bzero(pkg, sizeof(*pkg));
675ca987d46SWarner Losh 	pkg->pkg_fd = fd;
676ca987d46SWarner Losh 
677ca987d46SWarner Losh 	/*
678ca987d46SWarner Losh 	 * Parse the header.
679ca987d46SWarner Losh 	 */
680ca987d46SWarner Losh 	error = EFTYPE;
681ca987d46SWarner Losh 	ofs = 0;
682ca987d46SWarner Losh 
683ca987d46SWarner Losh 	/* Check megic. */
684ca987d46SWarner Losh 	if (get_byte(pkg, &ofs) != 0x1f || get_byte(pkg, &ofs) != 0x8b)
685ca987d46SWarner Losh 		goto fail;
686ca987d46SWarner Losh 	/* Check method. */
687ca987d46SWarner Losh 	if (get_byte(pkg, &ofs) != Z_DEFLATED)
688ca987d46SWarner Losh 		goto fail;
689ca987d46SWarner Losh 	/* Check flags. */
690ca987d46SWarner Losh 	flags = get_byte(pkg, &ofs);
691ca987d46SWarner Losh 	if (flags & RESERVED)
692ca987d46SWarner Losh 		goto fail;
693ca987d46SWarner Losh 
694ca987d46SWarner Losh 	/* Skip time, xflags and OS code. */
695ca987d46SWarner Losh 	for (i = 0; i < 6; i++) {
696ca987d46SWarner Losh 		if (get_byte(pkg, &ofs) == -1)
697ca987d46SWarner Losh 			goto fail;
698ca987d46SWarner Losh 	}
699ca987d46SWarner Losh 
700ca987d46SWarner Losh 	/* Skip extra field. */
701ca987d46SWarner Losh 	if (flags & EXTRA_FIELD) {
702ca987d46SWarner Losh 		i = (get_byte(pkg, &ofs) & 0xff) |
703ca987d46SWarner Losh 		    ((get_byte(pkg, &ofs) << 8) & 0xff);
704ca987d46SWarner Losh 		while (i-- > 0) {
705ca987d46SWarner Losh 			if (get_byte(pkg, &ofs) == -1)
706ca987d46SWarner Losh 				goto fail;
707ca987d46SWarner Losh 		}
708ca987d46SWarner Losh 	}
709ca987d46SWarner Losh 
710ca987d46SWarner Losh 	/* Skip original file name. */
711ca987d46SWarner Losh 	if (flags & ORIG_NAME) {
712ca987d46SWarner Losh 		do {
713ca987d46SWarner Losh 			i = get_byte(pkg, &ofs);
714ca987d46SWarner Losh 		} while (i != 0 && i != -1);
715ca987d46SWarner Losh 		if (i == -1)
716ca987d46SWarner Losh 			goto fail;
717ca987d46SWarner Losh 	}
718ca987d46SWarner Losh 
719ca987d46SWarner Losh 	/* Print the comment if it's there. */
720ca987d46SWarner Losh 	if (flags & COMMENT) {
721ca987d46SWarner Losh 		while (1) {
722ca987d46SWarner Losh 			i = get_byte(pkg, &ofs);
723ca987d46SWarner Losh 			if (i == -1)
724ca987d46SWarner Losh 				goto fail;
725ca987d46SWarner Losh 			if (i == 0)
726ca987d46SWarner Losh 				break;
727ca987d46SWarner Losh 			putchar(i);
728ca987d46SWarner Losh 		}
729ca987d46SWarner Losh 	}
730ca987d46SWarner Losh 
731ca987d46SWarner Losh 	/* Skip the CRC. */
732ca987d46SWarner Losh 	if (flags & HEAD_CRC) {
733ca987d46SWarner Losh 		if (get_byte(pkg, &ofs) == -1)
734ca987d46SWarner Losh 			goto fail;
735ca987d46SWarner Losh 		if (get_byte(pkg, &ofs) == -1)
736ca987d46SWarner Losh 			goto fail;
737ca987d46SWarner Losh 	}
738ca987d46SWarner Losh 
739ca987d46SWarner Losh 	/*
740*e67aef41SSimon J. Gerraty 	 * Done parsing the ZIP header. Start the inflation engine.
741ca987d46SWarner Losh 	 */
742ca987d46SWarner Losh 	error = inflateInit2(&pkg->pkg_zs, -15);
743ca987d46SWarner Losh 	if (error != Z_OK)
744ca987d46SWarner Losh 		goto fail;
745ca987d46SWarner Losh 
746ca987d46SWarner Losh 	*pp = pkg;
747ca987d46SWarner Losh 	return (0);
748ca987d46SWarner Losh 
749ca987d46SWarner Losh  fail:
750ca987d46SWarner Losh 	free(pkg);
751ca987d46SWarner Losh 	return (error);
752ca987d46SWarner Losh }
753ca987d46SWarner Losh 
754ca987d46SWarner Losh static struct tarfile *
scan_tarfile(struct package * pkg,struct tarfile * last)755ca987d46SWarner Losh scan_tarfile(struct package *pkg, struct tarfile *last)
756ca987d46SWarner Losh {
757ca987d46SWarner Losh 	char buf[512];
758ca987d46SWarner Losh 	struct tarfile *cur;
759ca987d46SWarner Losh 	off_t ofs;
760ca987d46SWarner Losh 	size_t sz;
761ca987d46SWarner Losh 
762ca987d46SWarner Losh 	cur = (last != NULL) ? last->tf_next : pkg->pkg_first;
763ca987d46SWarner Losh 	if (cur == NULL) {
764ca987d46SWarner Losh 		ofs = (last != NULL) ? last->tf_ofs + last->tf_size :
765ca987d46SWarner Losh 		    pkg->pkg_ofs;
766ca987d46SWarner Losh 		ofs = (ofs + 0x1ff) & ~0x1ff;
767ca987d46SWarner Losh 
768ca987d46SWarner Losh 		/* Check if we've reached EOF. */
769ca987d46SWarner Losh 		if (ofs < pkg->pkg_ofs) {
770ca987d46SWarner Losh 			errno = ENOSPC;
771ca987d46SWarner Losh 			return (NULL);
772ca987d46SWarner Losh 		}
773ca987d46SWarner Losh 
774ca987d46SWarner Losh 		if (ofs != pkg->pkg_ofs) {
775ca987d46SWarner Losh 			if (last != NULL && pkg->pkg_ofs == last->tf_ofs) {
776723f9041SSimon J. Gerraty 				if (cache_data(last, 0) == -1)
777ca987d46SWarner Losh 					return (NULL);
778ca987d46SWarner Losh 			} else {
779ca987d46SWarner Losh 				sz = ofs - pkg->pkg_ofs;
780ca987d46SWarner Losh 				while (sz != 0) {
781ca987d46SWarner Losh 					if (sz > sizeof(buf))
782ca987d46SWarner Losh 						sz = sizeof(buf);
783ca987d46SWarner Losh 					if (get_zipped(pkg, buf, sz) == -1)
784ca987d46SWarner Losh 						return (NULL);
785ca987d46SWarner Losh 					sz = ofs - pkg->pkg_ofs;
786ca987d46SWarner Losh 				}
787ca987d46SWarner Losh 			}
788ca987d46SWarner Losh 		}
789ca987d46SWarner Losh 
790ca987d46SWarner Losh 		cur = malloc(sizeof(*cur));
791ca987d46SWarner Losh 		if (cur == NULL)
792ca987d46SWarner Losh 			return (NULL);
793ca987d46SWarner Losh 		memset(cur, 0, sizeof(*cur));
794ca987d46SWarner Losh 		cur->tf_pkg = pkg;
795ca987d46SWarner Losh 
796ca987d46SWarner Losh 		while (1) {
797ca987d46SWarner Losh 			if (get_zipped(pkg, &cur->tf_hdr,
798ca987d46SWarner Losh 			    sizeof(cur->tf_hdr)) == -1) {
799ca987d46SWarner Losh 				free(cur);
800ca987d46SWarner Losh 				return (NULL);
801ca987d46SWarner Losh 			}
802ca987d46SWarner Losh 
803ca987d46SWarner Losh 			/*
804ca987d46SWarner Losh 			 * There are always 2 empty blocks appended to
805ca987d46SWarner Losh 			 * a PKG. It marks the end of the archive.
806ca987d46SWarner Losh 			 */
807ca987d46SWarner Losh 			if (strncmp(cur->tf_hdr.ut_magic, "ustar", 5) != 0) {
808ca987d46SWarner Losh 				free(cur);
809ca987d46SWarner Losh 				errno = ENOSPC;
810ca987d46SWarner Losh 				return (NULL);
811ca987d46SWarner Losh 			}
812ca987d46SWarner Losh 
813ca987d46SWarner Losh 			cur->tf_ofs = pkg->pkg_ofs;
814ca987d46SWarner Losh 			cur->tf_size = pkg_atol(cur->tf_hdr.ut_size,
815ca987d46SWarner Losh 			    sizeof(cur->tf_hdr.ut_size));
816ca987d46SWarner Losh 
817ca987d46SWarner Losh 			if (cur->tf_hdr.ut_name[0] != '+')
818ca987d46SWarner Losh 				break;
819ca987d46SWarner Losh 
820ca987d46SWarner Losh 			/*
821ca987d46SWarner Losh 			 * Skip package meta-files.
822ca987d46SWarner Losh 			 */
823ca987d46SWarner Losh 			ofs = cur->tf_ofs + cur->tf_size;
824ca987d46SWarner Losh 			ofs = (ofs + 0x1ff) & ~0x1ff;
825ca987d46SWarner Losh 			while (pkg->pkg_ofs < ofs) {
826ca987d46SWarner Losh 				if (get_zipped(pkg, buf, sizeof(buf)) == -1) {
827ca987d46SWarner Losh 					free(cur);
828ca987d46SWarner Losh 					return (NULL);
829ca987d46SWarner Losh 				}
830ca987d46SWarner Losh 			}
831ca987d46SWarner Losh 		}
832ca987d46SWarner Losh 
833ca987d46SWarner Losh 		if (last != NULL)
834ca987d46SWarner Losh 			last->tf_next = cur;
835ca987d46SWarner Losh 		else
836ca987d46SWarner Losh 			pkg->pkg_first = cur;
837ca987d46SWarner Losh 		pkg->pkg_last = cur;
838ca987d46SWarner Losh 	}
839ca987d46SWarner Losh 
840ca987d46SWarner Losh 	return (cur);
841ca987d46SWarner Losh }
842