inode.c revision 1.65 1 1.65 dholland /* $NetBSD: inode.c,v 1.65 2013/01/22 09:39:11 dholland Exp $ */
2 1.13 cgd
3 1.1 cgd /*
4 1.9 mycroft * Copyright (c) 1980, 1986, 1993
5 1.9 mycroft * The Regents of the University of California. All rights reserved.
6 1.1 cgd *
7 1.1 cgd * Redistribution and use in source and binary forms, with or without
8 1.1 cgd * modification, are permitted provided that the following conditions
9 1.1 cgd * are met:
10 1.1 cgd * 1. Redistributions of source code must retain the above copyright
11 1.1 cgd * notice, this list of conditions and the following disclaimer.
12 1.1 cgd * 2. Redistributions in binary form must reproduce the above copyright
13 1.1 cgd * notice, this list of conditions and the following disclaimer in the
14 1.1 cgd * documentation and/or other materials provided with the distribution.
15 1.40 agc * 3. Neither the name of the University nor the names of its contributors
16 1.1 cgd * may be used to endorse or promote products derived from this software
17 1.1 cgd * without specific prior written permission.
18 1.1 cgd *
19 1.1 cgd * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
20 1.1 cgd * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
21 1.1 cgd * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
22 1.1 cgd * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
23 1.1 cgd * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
24 1.1 cgd * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
25 1.1 cgd * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
26 1.1 cgd * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
27 1.1 cgd * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
28 1.1 cgd * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
29 1.1 cgd * SUCH DAMAGE.
30 1.1 cgd */
31 1.1 cgd
32 1.24 lukem #include <sys/cdefs.h>
33 1.1 cgd #ifndef lint
34 1.13 cgd #if 0
35 1.26 lukem static char sccsid[] = "@(#)inode.c 8.8 (Berkeley) 4/28/95";
36 1.13 cgd #else
37 1.65 dholland __RCSID("$NetBSD: inode.c,v 1.65 2013/01/22 09:39:11 dholland Exp $");
38 1.13 cgd #endif
39 1.1 cgd #endif /* not lint */
40 1.1 cgd
41 1.1 cgd #include <sys/param.h>
42 1.7 cgd #include <sys/time.h>
43 1.64 bouyer #include <sys/stat.h>
44 1.26 lukem
45 1.9 mycroft #include <ufs/ufs/dinode.h>
46 1.9 mycroft #include <ufs/ufs/dir.h>
47 1.9 mycroft #include <ufs/ffs/fs.h>
48 1.27 bouyer #include <ufs/ffs/ffs_extern.h>
49 1.32 fvdl #include <ufs/ufs/ufs_bswap.h>
50 1.28 kleink
51 1.6 cgd #ifndef SMALL
52 1.26 lukem #include <err.h>
53 1.1 cgd #include <pwd.h>
54 1.6 cgd #endif
55 1.12 cgd #include <stdio.h>
56 1.1 cgd #include <stdlib.h>
57 1.1 cgd #include <string.h>
58 1.28 kleink #include <time.h>
59 1.12 cgd
60 1.1 cgd #include "fsck.h"
61 1.22 christos #include "fsutil.h"
62 1.12 cgd #include "extern.h"
63 1.1 cgd
64 1.1 cgd static ino_t startinum;
65 1.1 cgd
66 1.51 xtraeme static int iblock(struct inodesc *, long, u_int64_t);
67 1.37 fvdl static void swap_dinode1(union dinode *, int);
68 1.37 fvdl static void swap_dinode2(union dinode *, int);
69 1.12 cgd
70 1.12 cgd int
71 1.50 xtraeme ckinode(union dinode *dp, struct inodesc *idesc)
72 1.1 cgd {
73 1.37 fvdl int ret, offset, i;
74 1.37 fvdl union dinode dino;
75 1.27 bouyer u_int64_t sizepb;
76 1.27 bouyer int64_t remsize;
77 1.37 fvdl daddr_t ndb;
78 1.9 mycroft mode_t mode;
79 1.23 thorpej char pathbuf[MAXPATHLEN + 1];
80 1.1 cgd
81 1.1 cgd if (idesc->id_fix != IGNORE)
82 1.1 cgd idesc->id_fix = DONTKNOW;
83 1.1 cgd idesc->id_entryno = 0;
84 1.37 fvdl idesc->id_filesize = iswap64(DIP(dp, size));
85 1.37 fvdl mode = iswap16(DIP(dp, mode)) & IFMT;
86 1.9 mycroft if (mode == IFBLK || mode == IFCHR || (mode == IFLNK &&
87 1.27 bouyer (idesc->id_filesize < sblock->fs_maxsymlinklen ||
88 1.35 dbj (isappleufs && (idesc->id_filesize < APPLEUFS_MAXSYMLINKLEN)) ||
89 1.37 fvdl (sblock->fs_maxsymlinklen == 0 && DIP(dp, blocks) == 0))))
90 1.1 cgd return (KEEPON);
91 1.37 fvdl if (is_ufs2)
92 1.37 fvdl dino.dp2 = dp->dp2;
93 1.37 fvdl else
94 1.37 fvdl dino.dp1 = dp->dp1;
95 1.37 fvdl ndb = howmany(iswap64(DIP(&dino, size)), sblock->fs_bsize);
96 1.65 dholland for (i = 0; i < UFS_NDADDR; i++) {
97 1.27 bouyer if (--ndb == 0 &&
98 1.37 fvdl (offset = blkoff(sblock, iswap64(DIP(&dino, size)))) != 0)
99 1.1 cgd idesc->id_numfrags =
100 1.27 bouyer numfrags(sblock, fragroundup(sblock, offset));
101 1.1 cgd else
102 1.27 bouyer idesc->id_numfrags = sblock->fs_frag;
103 1.37 fvdl if (DIP(&dino, db[i]) == 0) {
104 1.23 thorpej if (idesc->id_type == DATA && ndb >= 0) {
105 1.23 thorpej /* An empty block in a directory XXX */
106 1.27 bouyer markclean = 0;
107 1.39 itojun getpathname(pathbuf, sizeof(pathbuf),
108 1.39 itojun idesc->id_number, idesc->id_number);
109 1.53 christos pfatal("DIRECTORY %s: CONTAINS EMPTY BLOCKS",
110 1.23 thorpej pathbuf);
111 1.23 thorpej if (reply("ADJUST LENGTH") == 1) {
112 1.23 thorpej dp = ginode(idesc->id_number);
113 1.57 skrll DIP_SET(dp, size, iswap64(i *
114 1.57 skrll sblock->fs_bsize));
115 1.23 thorpej printf(
116 1.23 thorpej "YOU MUST RERUN FSCK AFTERWARDS\n");
117 1.23 thorpej rerun = 1;
118 1.23 thorpej inodirty();
119 1.23 thorpej }
120 1.23 thorpej }
121 1.1 cgd continue;
122 1.23 thorpej }
123 1.37 fvdl if (is_ufs2)
124 1.37 fvdl idesc->id_blkno = iswap64(dino.dp2.di_db[i]);
125 1.37 fvdl else
126 1.37 fvdl idesc->id_blkno = iswap32(dino.dp1.di_db[i]);
127 1.47 hannken if (idesc->id_type != DATA)
128 1.1 cgd ret = (*idesc->id_func)(idesc);
129 1.1 cgd else
130 1.1 cgd ret = dirscan(idesc);
131 1.1 cgd if (ret & STOP)
132 1.1 cgd return (ret);
133 1.1 cgd }
134 1.27 bouyer idesc->id_numfrags = sblock->fs_frag;
135 1.65 dholland remsize = iswap64(DIP(&dino, size)) - sblock->fs_bsize * UFS_NDADDR;
136 1.27 bouyer sizepb = sblock->fs_bsize;
137 1.65 dholland for (i = 0; i < UFS_NIADDR; i++) {
138 1.37 fvdl if (DIP(&dino, ib[i])) {
139 1.37 fvdl if (is_ufs2)
140 1.37 fvdl idesc->id_blkno = iswap64(dino.dp2.di_ib[i]);
141 1.37 fvdl else
142 1.37 fvdl idesc->id_blkno = iswap32(dino.dp1.di_ib[i]);
143 1.37 fvdl ret = iblock(idesc, i + 1, remsize);
144 1.1 cgd if (ret & STOP)
145 1.1 cgd return (ret);
146 1.23 thorpej } else {
147 1.23 thorpej if (idesc->id_type == DATA && remsize > 0) {
148 1.23 thorpej /* An empty block in a directory XXX */
149 1.27 bouyer markclean = 0;
150 1.39 itojun getpathname(pathbuf, sizeof(pathbuf),
151 1.39 itojun idesc->id_number, idesc->id_number);
152 1.23 thorpej pfatal("DIRECTORY %s: CONTAINS EMPTY BLOCKS",
153 1.23 thorpej pathbuf);
154 1.23 thorpej if (reply("ADJUST LENGTH") == 1) {
155 1.23 thorpej dp = ginode(idesc->id_number);
156 1.57 skrll DIP_SET(dp, size,
157 1.37 fvdl iswap64(iswap64(DIP(dp, size))
158 1.57 skrll - remsize));
159 1.23 thorpej remsize = 0;
160 1.23 thorpej printf(
161 1.23 thorpej "YOU MUST RERUN FSCK AFTERWARDS\n");
162 1.23 thorpej rerun = 1;
163 1.23 thorpej inodirty();
164 1.23 thorpej break;
165 1.23 thorpej }
166 1.23 thorpej }
167 1.1 cgd }
168 1.27 bouyer sizepb *= NINDIR(sblock);
169 1.9 mycroft remsize -= sizepb;
170 1.1 cgd }
171 1.1 cgd return (KEEPON);
172 1.1 cgd }
173 1.1 cgd
174 1.21 christos static int
175 1.50 xtraeme iblock(struct inodesc *idesc, long ilevel, u_int64_t isize)
176 1.1 cgd {
177 1.24 lukem struct bufarea *bp;
178 1.50 xtraeme int i, n, (*func) (struct inodesc *), nif;
179 1.19 mycroft u_int64_t sizepb;
180 1.1 cgd char buf[BUFSIZ];
181 1.23 thorpej char pathbuf[MAXPATHLEN + 1];
182 1.37 fvdl union dinode *dp;
183 1.1 cgd
184 1.47 hannken if (idesc->id_type != DATA) {
185 1.1 cgd func = idesc->id_func;
186 1.1 cgd if (((n = (*func)(idesc)) & KEEPON) == 0)
187 1.1 cgd return (n);
188 1.1 cgd } else
189 1.1 cgd func = dirscan;
190 1.1 cgd if (chkrange(idesc->id_blkno, idesc->id_numfrags))
191 1.1 cgd return (SKIP);
192 1.27 bouyer bp = getdatablk(idesc->id_blkno, sblock->fs_bsize);
193 1.1 cgd ilevel--;
194 1.27 bouyer for (sizepb = sblock->fs_bsize, i = 0; i < ilevel; i++)
195 1.27 bouyer sizepb *= NINDIR(sblock);
196 1.62 lukem if (howmany(isize, sizepb) > (size_t)NINDIR(sblock))
197 1.27 bouyer nif = NINDIR(sblock);
198 1.18 mycroft else
199 1.18 mycroft nif = howmany(isize, sizepb);
200 1.27 bouyer if (do_blkswap) { /* swap byte order of the whole blk */
201 1.37 fvdl if (is_ufs2) {
202 1.37 fvdl for (i = 0; i < nif; i++)
203 1.37 fvdl bp->b_un.b_indir2[i] =
204 1.37 fvdl bswap64(bp->b_un.b_indir2[i]);
205 1.37 fvdl } else {
206 1.37 fvdl for (i = 0; i < nif; i++)
207 1.37 fvdl bp->b_un.b_indir1[i] =
208 1.38 fvdl bswap32(bp->b_un.b_indir1[i]);
209 1.37 fvdl }
210 1.27 bouyer dirty(bp);
211 1.27 bouyer flush(fswritefd, bp);
212 1.27 bouyer }
213 1.27 bouyer if (idesc->id_func == pass1check && nif < NINDIR(sblock)) {
214 1.37 fvdl for (i = nif; i < NINDIR(sblock); i++) {
215 1.37 fvdl if (IBLK(bp, i) == 0)
216 1.1 cgd continue;
217 1.29 mycroft (void)snprintf(buf, sizeof(buf),
218 1.56 christos "PARTIALLY TRUNCATED INODE I=%llu",
219 1.56 christos (unsigned long long)idesc->id_number);
220 1.1 cgd if (dofix(idesc, buf)) {
221 1.57 skrll IBLK_SET(bp, i, 0);
222 1.1 cgd dirty(bp);
223 1.27 bouyer } else
224 1.60 simonb markclean = 0;
225 1.1 cgd }
226 1.1 cgd flush(fswritefd, bp);
227 1.1 cgd }
228 1.37 fvdl for (i = 0; i < nif; i++) {
229 1.37 fvdl if (IBLK(bp, i)) {
230 1.37 fvdl if (is_ufs2)
231 1.37 fvdl idesc->id_blkno = iswap64(bp->b_un.b_indir2[i]);
232 1.37 fvdl else
233 1.37 fvdl idesc->id_blkno = iswap32(bp->b_un.b_indir1[i]);
234 1.9 mycroft if (ilevel == 0)
235 1.9 mycroft n = (*func)(idesc);
236 1.1 cgd else
237 1.9 mycroft n = iblock(idesc, ilevel, isize);
238 1.1 cgd if (n & STOP) {
239 1.1 cgd bp->b_flags &= ~B_INUSE;
240 1.1 cgd return (n);
241 1.23 thorpej }
242 1.23 thorpej } else {
243 1.23 thorpej if (idesc->id_type == DATA && isize > 0) {
244 1.23 thorpej /* An empty block in a directory XXX */
245 1.60 simonb markclean = 0;
246 1.39 itojun getpathname(pathbuf, sizeof(pathbuf),
247 1.39 itojun idesc->id_number, idesc->id_number);
248 1.23 thorpej pfatal("DIRECTORY %s: CONTAINS EMPTY BLOCKS",
249 1.23 thorpej pathbuf);
250 1.23 thorpej if (reply("ADJUST LENGTH") == 1) {
251 1.23 thorpej dp = ginode(idesc->id_number);
252 1.57 skrll DIP_SET(dp, size,
253 1.37 fvdl iswap64(iswap64(DIP(dp, size))
254 1.57 skrll - isize));
255 1.23 thorpej isize = 0;
256 1.23 thorpej printf(
257 1.23 thorpej "YOU MUST RERUN FSCK AFTERWARDS\n");
258 1.23 thorpej rerun = 1;
259 1.23 thorpej inodirty();
260 1.23 thorpej bp->b_flags &= ~B_INUSE;
261 1.23 thorpej return(STOP);
262 1.23 thorpej }
263 1.1 cgd }
264 1.1 cgd }
265 1.9 mycroft isize -= sizepb;
266 1.1 cgd }
267 1.1 cgd bp->b_flags &= ~B_INUSE;
268 1.1 cgd return (KEEPON);
269 1.1 cgd }
270 1.1 cgd
271 1.1 cgd /*
272 1.1 cgd * Check that a block in a legal block number.
273 1.1 cgd * Return 0 if in range, 1 if out of range.
274 1.1 cgd */
275 1.12 cgd int
276 1.50 xtraeme chkrange(daddr_t blk, int cnt)
277 1.1 cgd {
278 1.24 lukem int c;
279 1.1 cgd
280 1.46 dbj if (cnt <= 0 || blk <= 0 || blk > maxfsblock ||
281 1.46 dbj cnt - 1 > maxfsblock - blk)
282 1.1 cgd return (1);
283 1.37 fvdl if (cnt > sblock->fs_frag ||
284 1.37 fvdl fragnum(sblock, blk) + cnt > sblock->fs_frag) {
285 1.37 fvdl if (debug)
286 1.37 fvdl printf("bad size: blk %lld, offset %d, size %d\n",
287 1.37 fvdl (long long)blk, (int)fragnum(sblock, blk), cnt);
288 1.37 fvdl }
289 1.27 bouyer c = dtog(sblock, blk);
290 1.27 bouyer if (blk < cgdmin(sblock, c)) {
291 1.27 bouyer if ((blk + cnt) > cgsblock(sblock, c)) {
292 1.1 cgd if (debug) {
293 1.36 fvdl printf("blk %lld < cgdmin %lld;",
294 1.36 fvdl (long long)blk,
295 1.36 fvdl (long long)cgdmin(sblock, c));
296 1.36 fvdl printf(" blk + cnt %lld > cgsbase %lld\n",
297 1.36 fvdl (long long)(blk + cnt),
298 1.36 fvdl (long long)cgsblock(sblock, c));
299 1.1 cgd }
300 1.1 cgd return (1);
301 1.1 cgd }
302 1.1 cgd } else {
303 1.27 bouyer if ((blk + cnt) > cgbase(sblock, c+1)) {
304 1.1 cgd if (debug) {
305 1.36 fvdl printf("blk %lld >= cgdmin %lld;",
306 1.36 fvdl (long long)blk,
307 1.36 fvdl (long long)cgdmin(sblock, c));
308 1.36 fvdl printf(" blk + cnt %lld > sblock->fs_fpg %d\n",
309 1.36 fvdl (long long)(blk+cnt), sblock->fs_fpg);
310 1.1 cgd }
311 1.1 cgd return (1);
312 1.1 cgd }
313 1.1 cgd }
314 1.1 cgd return (0);
315 1.1 cgd }
316 1.1 cgd
317 1.1 cgd /*
318 1.1 cgd * General purpose interface for reading inodes.
319 1.1 cgd */
320 1.37 fvdl union dinode *
321 1.50 xtraeme ginode(ino_t inumber)
322 1.1 cgd {
323 1.36 fvdl daddr_t iblk;
324 1.30 thorpej int blkoff;
325 1.1 cgd
326 1.65 dholland if (inumber < UFS_ROOTINO || inumber > maxino)
327 1.59 christos errexit("bad inode number %llu to ginode",
328 1.56 christos (unsigned long long)inumber);
329 1.1 cgd if (startinum == 0 ||
330 1.27 bouyer inumber < startinum || inumber >= startinum + INOPB(sblock)) {
331 1.27 bouyer iblk = ino_to_fsba(sblock, inumber);
332 1.1 cgd if (pbp != 0)
333 1.1 cgd pbp->b_flags &= ~B_INUSE;
334 1.27 bouyer pbp = getdatablk(iblk, sblock->fs_bsize);
335 1.27 bouyer startinum = (inumber / INOPB(sblock)) * INOPB(sblock);
336 1.1 cgd }
337 1.37 fvdl if (is_ufs2) {
338 1.37 fvdl blkoff = (inumber % INOPB(sblock)) * DINODE2_SIZE;
339 1.37 fvdl return ((union dinode *)((caddr_t)pbp->b_un.b_buf + blkoff));
340 1.37 fvdl }
341 1.37 fvdl blkoff = (inumber % INOPB(sblock)) * DINODE1_SIZE;
342 1.37 fvdl return ((union dinode *)((caddr_t)pbp->b_un.b_buf + blkoff));
343 1.37 fvdl }
344 1.37 fvdl
345 1.37 fvdl static void
346 1.37 fvdl swap_dinode1(union dinode *dp, int n)
347 1.37 fvdl {
348 1.37 fvdl int i, j;
349 1.37 fvdl struct ufs1_dinode *dp1;
350 1.45 dbj int32_t maxsymlinklen = sblock->fs_maxsymlinklen;
351 1.45 dbj if (isappleufs)
352 1.45 dbj maxsymlinklen = APPLEUFS_MAXSYMLINKLEN;
353 1.37 fvdl
354 1.37 fvdl dp1 = (struct ufs1_dinode *)&dp->dp1;
355 1.37 fvdl for (i = 0; i < n; i++, dp1++) {
356 1.37 fvdl ffs_dinode1_swap(dp1, dp1);
357 1.42 dbj if (((iswap16(dp1->di_mode) & IFMT) != IFLNK) ||
358 1.44 dbj doinglevel2 ||
359 1.45 dbj (maxsymlinklen < 0) ||
360 1.62 lukem (iswap64(dp1->di_size) > (uint64_t)maxsymlinklen)) {
361 1.65 dholland for (j = 0; j < (UFS_NDADDR + UFS_NIADDR); j++)
362 1.37 fvdl dp1->di_db[j] = bswap32(dp1->di_db[j]);
363 1.37 fvdl }
364 1.37 fvdl }
365 1.37 fvdl }
366 1.37 fvdl
367 1.37 fvdl static void
368 1.37 fvdl swap_dinode2(union dinode *dp, int n)
369 1.37 fvdl {
370 1.37 fvdl int i, j;
371 1.37 fvdl struct ufs2_dinode *dp2;
372 1.37 fvdl
373 1.37 fvdl dp2 = (struct ufs2_dinode *)&dp->dp2;
374 1.37 fvdl for (i = 0; i < n; i++, dp2++) {
375 1.37 fvdl ffs_dinode2_swap(dp2, dp2);
376 1.37 fvdl if ((iswap16(dp2->di_mode) & IFMT) != IFLNK) {
377 1.65 dholland for (j = 0; j < (UFS_NDADDR + UFS_NIADDR + UFS_NXADDR); j++)
378 1.37 fvdl dp2->di_extb[j] = bswap64(dp2->di_extb[j]);
379 1.37 fvdl }
380 1.37 fvdl }
381 1.1 cgd }
382 1.1 cgd
383 1.1 cgd /*
384 1.1 cgd * Special purpose version of ginode used to optimize first pass
385 1.1 cgd * over all the inodes in numerical order.
386 1.1 cgd */
387 1.37 fvdl ino_t nextino, lastinum, lastvalidinum;
388 1.1 cgd long readcnt, readpercg, fullcnt, inobufsize, partialcnt, partialsize;
389 1.37 fvdl union dinode *inodebuf;
390 1.1 cgd
391 1.37 fvdl union dinode *
392 1.50 xtraeme getnextinode(ino_t inumber)
393 1.1 cgd {
394 1.1 cgd long size;
395 1.36 fvdl daddr_t dblk;
396 1.37 fvdl static union dinode *dp;
397 1.37 fvdl union dinode *ret;
398 1.1 cgd
399 1.52 christos if (inumber != nextino++ || inumber > lastvalidinum)
400 1.59 christos errexit("bad inode number %llu to nextinode",
401 1.56 christos (unsigned long long)inumber);
402 1.37 fvdl
403 1.1 cgd if (inumber >= lastinum) {
404 1.1 cgd readcnt++;
405 1.27 bouyer dblk = fsbtodb(sblock, ino_to_fsba(sblock, lastinum));
406 1.1 cgd if (readcnt % readpercg == 0) {
407 1.1 cgd size = partialsize;
408 1.1 cgd lastinum += partialcnt;
409 1.1 cgd } else {
410 1.1 cgd size = inobufsize;
411 1.1 cgd lastinum += fullcnt;
412 1.1 cgd }
413 1.37 fvdl (void)bread(fsreadfd, (caddr_t)inodebuf, dblk, size);
414 1.27 bouyer if (doswap) {
415 1.37 fvdl if (is_ufs2)
416 1.37 fvdl swap_dinode2(inodebuf, lastinum - inumber);
417 1.37 fvdl else
418 1.37 fvdl swap_dinode1(inodebuf, lastinum - inumber);
419 1.27 bouyer bwrite(fswritefd, (char *)inodebuf, dblk, size);
420 1.27 bouyer }
421 1.37 fvdl dp = (union dinode *)inodebuf;
422 1.1 cgd }
423 1.37 fvdl ret = dp;
424 1.37 fvdl dp = (union dinode *)
425 1.37 fvdl ((char *)dp + (is_ufs2 ? DINODE2_SIZE : DINODE1_SIZE));
426 1.37 fvdl return ret;
427 1.1 cgd }
428 1.1 cgd
429 1.12 cgd void
430 1.50 xtraeme setinodebuf(ino_t inum)
431 1.1 cgd {
432 1.1 cgd
433 1.37 fvdl if (inum % sblock->fs_ipg != 0)
434 1.59 christos errexit("bad inode number %llu to setinodebuf",
435 1.56 christos (unsigned long long)inum);
436 1.37 fvdl
437 1.37 fvdl lastvalidinum = inum + sblock->fs_ipg - 1;
438 1.1 cgd startinum = 0;
439 1.37 fvdl nextino = inum;
440 1.37 fvdl lastinum = inum;
441 1.1 cgd readcnt = 0;
442 1.37 fvdl if (inodebuf != NULL)
443 1.37 fvdl return;
444 1.27 bouyer inobufsize = blkroundup(sblock, INOBUFSIZE);
445 1.37 fvdl fullcnt = inobufsize / (is_ufs2 ? DINODE2_SIZE : DINODE1_SIZE);
446 1.27 bouyer readpercg = sblock->fs_ipg / fullcnt;
447 1.27 bouyer partialcnt = sblock->fs_ipg % fullcnt;
448 1.37 fvdl partialsize = partialcnt * (is_ufs2 ? DINODE2_SIZE : DINODE1_SIZE);
449 1.1 cgd if (partialcnt != 0) {
450 1.1 cgd readpercg++;
451 1.1 cgd } else {
452 1.1 cgd partialcnt = fullcnt;
453 1.1 cgd partialsize = inobufsize;
454 1.1 cgd }
455 1.1 cgd if (inodebuf == NULL &&
456 1.37 fvdl (inodebuf = malloc((unsigned)inobufsize)) == NULL)
457 1.59 christos errexit("Cannot allocate space for inode buffer");
458 1.1 cgd }
459 1.1 cgd
460 1.12 cgd void
461 1.50 xtraeme freeinodebuf(void)
462 1.1 cgd {
463 1.1 cgd
464 1.1 cgd if (inodebuf != NULL)
465 1.1 cgd free((char *)inodebuf);
466 1.1 cgd inodebuf = NULL;
467 1.1 cgd }
468 1.1 cgd
469 1.1 cgd /*
470 1.1 cgd * Routines to maintain information about directory inodes.
471 1.1 cgd * This is built during the first pass and used during the
472 1.1 cgd * second and third passes.
473 1.1 cgd *
474 1.1 cgd * Enter inodes into the cache.
475 1.1 cgd */
476 1.12 cgd void
477 1.50 xtraeme cacheino(union dinode *dp, ino_t inumber)
478 1.1 cgd {
479 1.24 lukem struct inoinfo *inp;
480 1.41 itojun struct inoinfo **inpp, **ninpsort;
481 1.62 lukem unsigned int i, blks, extra;
482 1.37 fvdl int64_t size;
483 1.1 cgd
484 1.37 fvdl size = iswap64(DIP(dp, size));
485 1.37 fvdl blks = howmany(size, sblock->fs_bsize);
486 1.65 dholland if (blks > UFS_NDADDR)
487 1.65 dholland blks = UFS_NDADDR + UFS_NIADDR;
488 1.58 chs if (blks > 0)
489 1.58 chs extra = (blks - 1) * sizeof (int64_t);
490 1.58 chs else
491 1.58 chs extra = 0;
492 1.58 chs inp = malloc(sizeof(*inp) + extra);
493 1.1 cgd if (inp == NULL)
494 1.1 cgd return;
495 1.37 fvdl inpp = &inphead[inumber % dirhash];
496 1.1 cgd inp->i_nexthash = *inpp;
497 1.1 cgd *inpp = inp;
498 1.48 mycroft inp->i_child = inp->i_sibling = 0;
499 1.65 dholland if (inumber == UFS_ROOTINO)
500 1.65 dholland inp->i_parent = UFS_ROOTINO;
501 1.14 mycroft else
502 1.14 mycroft inp->i_parent = (ino_t)0;
503 1.1 cgd inp->i_dotdot = (ino_t)0;
504 1.1 cgd inp->i_number = inumber;
505 1.37 fvdl inp->i_isize = size;
506 1.37 fvdl inp->i_numblks = blks;
507 1.65 dholland for (i = 0; i < (blks < UFS_NDADDR ? blks : UFS_NDADDR); i++)
508 1.37 fvdl inp->i_blks[i] = DIP(dp, db[i]);
509 1.65 dholland if (blks > UFS_NDADDR)
510 1.65 dholland for (i = 0; i < UFS_NIADDR; i++)
511 1.65 dholland inp->i_blks[UFS_NDADDR + i] = DIP(dp, ib[i]);
512 1.1 cgd if (inplast == listmax) {
513 1.41 itojun ninpsort = (struct inoinfo **)realloc((char *)inpsort,
514 1.41 itojun (unsigned)(listmax + 100) * sizeof(struct inoinfo *));
515 1.1 cgd if (inpsort == NULL)
516 1.59 christos errexit("cannot increase directory list");
517 1.41 itojun inpsort = ninpsort;
518 1.41 itojun listmax += 100;
519 1.1 cgd }
520 1.1 cgd inpsort[inplast++] = inp;
521 1.1 cgd }
522 1.1 cgd
523 1.1 cgd /*
524 1.1 cgd * Look up an inode cache structure.
525 1.1 cgd */
526 1.1 cgd struct inoinfo *
527 1.50 xtraeme getinoinfo(ino_t inumber)
528 1.1 cgd {
529 1.24 lukem struct inoinfo *inp;
530 1.1 cgd
531 1.37 fvdl for (inp = inphead[inumber % dirhash]; inp; inp = inp->i_nexthash) {
532 1.1 cgd if (inp->i_number != inumber)
533 1.1 cgd continue;
534 1.1 cgd return (inp);
535 1.1 cgd }
536 1.59 christos errexit("cannot find inode %llu", (unsigned long long)inumber);
537 1.1 cgd return ((struct inoinfo *)0);
538 1.1 cgd }
539 1.1 cgd
540 1.1 cgd /*
541 1.1 cgd * Clean up all the inode cache structure.
542 1.1 cgd */
543 1.12 cgd void
544 1.50 xtraeme inocleanup(void)
545 1.1 cgd {
546 1.24 lukem struct inoinfo **inpp;
547 1.1 cgd
548 1.1 cgd if (inphead == NULL)
549 1.1 cgd return;
550 1.1 cgd for (inpp = &inpsort[inplast - 1]; inpp >= inpsort; inpp--)
551 1.1 cgd free((char *)(*inpp));
552 1.1 cgd free((char *)inphead);
553 1.1 cgd free((char *)inpsort);
554 1.1 cgd inphead = inpsort = NULL;
555 1.1 cgd }
556 1.9 mycroft
557 1.12 cgd void
558 1.50 xtraeme inodirty(void)
559 1.1 cgd {
560 1.1 cgd
561 1.1 cgd dirty(pbp);
562 1.1 cgd }
563 1.1 cgd
564 1.12 cgd void
565 1.55 christos clri(struct inodesc *idesc, const char *type, int flag)
566 1.1 cgd {
567 1.37 fvdl union dinode *dp;
568 1.1 cgd
569 1.1 cgd dp = ginode(idesc->id_number);
570 1.1 cgd if (flag == 1) {
571 1.1 cgd pwarn("%s %s", type,
572 1.37 fvdl (iswap16(DIP(dp, mode)) & IFMT) == IFDIR ? "DIR" : "FILE");
573 1.1 cgd pinode(idesc->id_number);
574 1.1 cgd }
575 1.1 cgd if (preen || reply("CLEAR") == 1) {
576 1.1 cgd if (preen)
577 1.1 cgd printf(" (CLEARED)\n");
578 1.1 cgd n_files--;
579 1.64 bouyer /*
580 1.64 bouyer * ckinode will call id_func (actually always pass4check)
581 1.64 bouyer * which will update the block count
582 1.64 bouyer */
583 1.64 bouyer if (idesc->id_type != SNAP)
584 1.64 bouyer update_uquot(idesc->id_number,
585 1.64 bouyer idesc->id_uid, idesc->id_gid, 0, -1);
586 1.1 cgd (void)ckinode(dp, idesc);
587 1.1 cgd clearinode(dp);
588 1.37 fvdl inoinfo(idesc->id_number)->ino_state = USTATE;
589 1.1 cgd inodirty();
590 1.27 bouyer } else
591 1.60 simonb markclean = 0;
592 1.1 cgd }
593 1.1 cgd
594 1.12 cgd int
595 1.50 xtraeme findname(struct inodesc *idesc)
596 1.1 cgd {
597 1.24 lukem struct direct *dirp = idesc->id_dirp;
598 1.55 christos size_t len;
599 1.55 christos char *buf;
600 1.1 cgd
601 1.37 fvdl if (iswap32(dirp->d_ino) != idesc->id_parent || idesc->id_entryno < 2) {
602 1.37 fvdl idesc->id_entryno++;
603 1.1 cgd return (KEEPON);
604 1.37 fvdl }
605 1.55 christos if ((len = dirp->d_namlen + 1) > MAXPATHLEN) {
606 1.55 christos /* XXX: We don't fix but we ignore */
607 1.55 christos len = MAXPATHLEN;
608 1.55 christos }
609 1.55 christos /* this is namebuf from utilities.c */
610 1.55 christos buf = __UNCONST(idesc->id_name);
611 1.55 christos (void)memcpy(buf, dirp->d_name, (size_t)dirp->d_namlen + 1);
612 1.1 cgd return (STOP|FOUND);
613 1.1 cgd }
614 1.1 cgd
615 1.12 cgd int
616 1.50 xtraeme findino(struct inodesc *idesc)
617 1.1 cgd {
618 1.24 lukem struct direct *dirp = idesc->id_dirp;
619 1.1 cgd
620 1.1 cgd if (dirp->d_ino == 0)
621 1.1 cgd return (KEEPON);
622 1.1 cgd if (strcmp(dirp->d_name, idesc->id_name) == 0 &&
623 1.65 dholland iswap32(dirp->d_ino) >= UFS_ROOTINO && iswap32(dirp->d_ino) <= maxino) {
624 1.27 bouyer idesc->id_parent = iswap32(dirp->d_ino);
625 1.1 cgd return (STOP|FOUND);
626 1.1 cgd }
627 1.1 cgd return (KEEPON);
628 1.1 cgd }
629 1.1 cgd
630 1.37 fvdl int
631 1.50 xtraeme clearentry(struct inodesc *idesc)
632 1.37 fvdl {
633 1.37 fvdl struct direct *dirp = idesc->id_dirp;
634 1.37 fvdl
635 1.37 fvdl if (dirp->d_ino != idesc->id_parent || idesc->id_entryno < 2) {
636 1.37 fvdl idesc->id_entryno++;
637 1.37 fvdl return (KEEPON);
638 1.37 fvdl }
639 1.37 fvdl dirp->d_ino = 0;
640 1.37 fvdl return (STOP|FOUND|ALTERED);
641 1.37 fvdl }
642 1.37 fvdl
643 1.12 cgd void
644 1.50 xtraeme pinode(ino_t ino)
645 1.1 cgd {
646 1.37 fvdl union dinode *dp;
647 1.1 cgd struct passwd *pw;
648 1.1 cgd
649 1.56 christos printf(" I=%llu ", (unsigned long long)ino);
650 1.65 dholland if (ino < UFS_ROOTINO || ino > maxino)
651 1.1 cgd return;
652 1.1 cgd dp = ginode(ino);
653 1.1 cgd printf(" OWNER=");
654 1.6 cgd #ifndef SMALL
655 1.61 christos if (Uflag && (pw = getpwuid((int)iswap32(DIP(dp, uid)))) != 0)
656 1.1 cgd printf("%s ", pw->pw_name);
657 1.1 cgd else
658 1.6 cgd #endif
659 1.37 fvdl printf("%u ", (unsigned)iswap32(DIP(dp, uid)));
660 1.37 fvdl printf("MODE=%o\n", iswap16(DIP(dp, mode)));
661 1.1 cgd if (preen)
662 1.21 christos printf("%s: ", cdevname());
663 1.37 fvdl printf("SIZE=%llu ", (unsigned long long)iswap64(DIP(dp, size)));
664 1.63 christos printf("MTIME=%s ", print_mtime(iswap32(DIP(dp, mtime))));
665 1.1 cgd }
666 1.1 cgd
667 1.12 cgd void
668 1.55 christos blkerror(ino_t ino, const char *type, daddr_t blk)
669 1.1 cgd {
670 1.37 fvdl struct inostat *info;
671 1.1 cgd
672 1.56 christos pfatal("%lld %s I=%llu", (long long)blk, type, (unsigned long long)ino);
673 1.1 cgd printf("\n");
674 1.37 fvdl info = inoinfo(ino);
675 1.37 fvdl switch (info->ino_state) {
676 1.1 cgd
677 1.1 cgd case FSTATE:
678 1.37 fvdl info->ino_state = FCLEAR;
679 1.1 cgd return;
680 1.1 cgd
681 1.1 cgd case DSTATE:
682 1.37 fvdl info->ino_state = DCLEAR;
683 1.1 cgd return;
684 1.1 cgd
685 1.1 cgd case FCLEAR:
686 1.1 cgd case DCLEAR:
687 1.1 cgd return;
688 1.1 cgd
689 1.1 cgd default:
690 1.59 christos errexit("BAD STATE %d TO BLKERR", info->ino_state);
691 1.1 cgd /* NOTREACHED */
692 1.1 cgd }
693 1.1 cgd }
694 1.1 cgd
695 1.1 cgd /*
696 1.1 cgd * allocate an unused inode
697 1.1 cgd */
698 1.1 cgd ino_t
699 1.50 xtraeme allocino(ino_t request, int type)
700 1.1 cgd {
701 1.24 lukem ino_t ino;
702 1.37 fvdl union dinode *dp;
703 1.37 fvdl struct ufs1_dinode *dp1;
704 1.37 fvdl struct ufs2_dinode *dp2;
705 1.16 thorpej time_t t;
706 1.32 fvdl struct cg *cgp = cgrp;
707 1.32 fvdl int cg;
708 1.54 lukem struct inostat *info = NULL;
709 1.64 bouyer int nfrags;
710 1.1 cgd
711 1.1 cgd if (request == 0)
712 1.65 dholland request = UFS_ROOTINO;
713 1.37 fvdl else if (inoinfo(request)->ino_state != USTATE)
714 1.1 cgd return (0);
715 1.37 fvdl for (ino = request; ino < maxino; ino++) {
716 1.37 fvdl info = inoinfo(ino);
717 1.37 fvdl if (info->ino_state == USTATE)
718 1.1 cgd break;
719 1.37 fvdl }
720 1.1 cgd if (ino == maxino)
721 1.1 cgd return (0);
722 1.32 fvdl cg = ino_to_cg(sblock, ino);
723 1.49 dbj /* If necessary, extend the inoinfo array. grow exponentially */
724 1.62 lukem if ((ino % sblock->fs_ipg) >= (uint64_t)inostathead[cg].il_numalloced) {
725 1.49 dbj unsigned long newalloced, i;
726 1.49 dbj newalloced = MIN(sblock->fs_ipg,
727 1.49 dbj MAX(2 * inostathead[cg].il_numalloced, 10));
728 1.49 dbj info = calloc(newalloced, sizeof(struct inostat));
729 1.49 dbj if (info == NULL) {
730 1.49 dbj pwarn("cannot alloc %lu bytes to extend inoinfo\n",
731 1.49 dbj sizeof(struct inostat) * newalloced);
732 1.49 dbj return 0;
733 1.49 dbj }
734 1.49 dbj memmove(info, inostathead[cg].il_stat,
735 1.49 dbj inostathead[cg].il_numalloced * sizeof(*info));
736 1.49 dbj for (i = inostathead[cg].il_numalloced; i < newalloced; i++) {
737 1.49 dbj info[i].ino_state = USTATE;
738 1.49 dbj }
739 1.49 dbj if (inostathead[cg].il_numalloced)
740 1.49 dbj free(inostathead[cg].il_stat);
741 1.49 dbj inostathead[cg].il_stat = info;
742 1.49 dbj inostathead[cg].il_numalloced = newalloced;
743 1.49 dbj info = inoinfo(ino);
744 1.49 dbj }
745 1.32 fvdl getblk(&cgblk, cgtod(sblock, cg), sblock->fs_cgsize);
746 1.32 fvdl memcpy(cgp, cgblk.b_un.b_cg, sblock->fs_cgsize);
747 1.32 fvdl if ((doswap && !needswap) || (!doswap && needswap))
748 1.37 fvdl ffs_cg_swap(cgblk.b_un.b_cg, cgp, sblock);
749 1.32 fvdl if (!cg_chkmagic(cgp, 0))
750 1.32 fvdl pfatal("CG %d: ALLOCINO: BAD MAGIC NUMBER\n", cg);
751 1.32 fvdl if (doswap)
752 1.32 fvdl cgdirty();
753 1.32 fvdl setbit(cg_inosused(cgp, 0), ino % sblock->fs_ipg);
754 1.32 fvdl cgp->cg_cs.cs_nifree--;
755 1.64 bouyer sblock->fs_cstotal.cs_nifree--;
756 1.64 bouyer sblock->fs_cs(fs, cg).cs_nifree--;
757 1.64 bouyer sbdirty();
758 1.1 cgd switch (type & IFMT) {
759 1.1 cgd case IFDIR:
760 1.37 fvdl info->ino_state = DSTATE;
761 1.32 fvdl cgp->cg_cs.cs_ndir++;
762 1.64 bouyer nfrags = 1;
763 1.1 cgd break;
764 1.1 cgd case IFREG:
765 1.64 bouyer info->ino_state = FSTATE;
766 1.64 bouyer nfrags = sblock->fs_frag;
767 1.64 bouyer break;
768 1.1 cgd case IFLNK:
769 1.37 fvdl info->ino_state = FSTATE;
770 1.64 bouyer nfrags = 1;
771 1.1 cgd break;
772 1.1 cgd default:
773 1.1 cgd return (0);
774 1.1 cgd }
775 1.32 fvdl cgdirty();
776 1.1 cgd dp = ginode(ino);
777 1.37 fvdl if (is_ufs2) {
778 1.37 fvdl dp2 = &dp->dp2;
779 1.64 bouyer dp2->di_db[0] = iswap64(allocblk(nfrags));
780 1.37 fvdl if (dp2->di_db[0] == 0) {
781 1.37 fvdl info->ino_state = USTATE;
782 1.37 fvdl return (0);
783 1.37 fvdl }
784 1.37 fvdl dp2->di_mode = iswap16(type);
785 1.37 fvdl dp2->di_flags = 0;
786 1.37 fvdl (void)time(&t);
787 1.37 fvdl dp2->di_atime = iswap64(t);
788 1.37 fvdl dp2->di_mtime = dp2->di_ctime = dp2->di_atime;
789 1.64 bouyer dp2->di_size = iswap64(lfragtosize(sblock, nfrags));
790 1.64 bouyer dp2->di_blocks = iswap64(btodb(lfragtosize(sblock, nfrags)));
791 1.37 fvdl } else {
792 1.37 fvdl dp1 = &dp->dp1;
793 1.64 bouyer dp1->di_db[0] = iswap32(allocblk(nfrags));
794 1.37 fvdl if (dp1->di_db[0] == 0) {
795 1.37 fvdl info->ino_state = USTATE;
796 1.37 fvdl return (0);
797 1.37 fvdl }
798 1.37 fvdl dp1->di_mode = iswap16(type);
799 1.37 fvdl dp1->di_flags = 0;
800 1.37 fvdl (void)time(&t);
801 1.37 fvdl dp1->di_atime = iswap32(t);
802 1.37 fvdl dp1->di_mtime = dp1->di_ctime = dp1->di_atime;
803 1.64 bouyer dp1->di_size = iswap64(lfragtosize(sblock, nfrags));
804 1.64 bouyer dp1->di_blocks = iswap32(btodb(lfragtosize(sblock, nfrags)));
805 1.1 cgd }
806 1.1 cgd n_files++;
807 1.1 cgd inodirty();
808 1.9 mycroft if (newinofmt)
809 1.37 fvdl info->ino_type = IFTODT(type);
810 1.1 cgd return (ino);
811 1.1 cgd }
812 1.1 cgd
813 1.1 cgd /*
814 1.1 cgd * deallocate an inode
815 1.1 cgd */
816 1.12 cgd void
817 1.50 xtraeme freeino(ino_t ino)
818 1.1 cgd {
819 1.1 cgd struct inodesc idesc;
820 1.37 fvdl union dinode *dp;
821 1.64 bouyer struct cg *cgp = cgrp;
822 1.64 bouyer int cg;
823 1.64 bouyer
824 1.64 bouyer cg = ino_to_cg(sblock, ino);
825 1.64 bouyer getblk(&cgblk, cgtod(sblock, cg), sblock->fs_cgsize);
826 1.64 bouyer memcpy(cgp, cgblk.b_un.b_cg, sblock->fs_cgsize);
827 1.64 bouyer if ((doswap && !needswap) || (!doswap && needswap))
828 1.64 bouyer ffs_cg_swap(cgblk.b_un.b_cg, cgp, sblock);
829 1.64 bouyer if (!cg_chkmagic(cgp, 0)) {
830 1.64 bouyer pwarn("CG %d: FREEINO: BAD MAGIC NUMBER\n", cg);
831 1.64 bouyer cgp = NULL;
832 1.64 bouyer }
833 1.1 cgd
834 1.11 mycroft memset(&idesc, 0, sizeof(struct inodesc));
835 1.1 cgd idesc.id_func = pass4check;
836 1.1 cgd idesc.id_number = ino;
837 1.1 cgd dp = ginode(ino);
838 1.64 bouyer idesc.id_uid = iswap32(DIP(dp, uid));
839 1.64 bouyer idesc.id_gid = iswap32(DIP(dp, gid));
840 1.64 bouyer if (iswap32(DIP(dp, flags)) & SF_SNAPSHOT)
841 1.64 bouyer idesc.id_type = SNAP;
842 1.64 bouyer else
843 1.64 bouyer idesc.id_type = ADDR;
844 1.1 cgd (void)ckinode(dp, &idesc);
845 1.1 cgd clearinode(dp);
846 1.1 cgd inodirty();
847 1.37 fvdl inoinfo(ino)->ino_state = USTATE;
848 1.64 bouyer if (idesc.id_type != SNAP)
849 1.64 bouyer update_uquot(idesc.id_number,
850 1.64 bouyer idesc.id_uid, idesc.id_gid, 0, -1);
851 1.1 cgd n_files--;
852 1.64 bouyer if (cgp) {
853 1.64 bouyer clrbit(cg_inosused(cgp, 0), ino % sblock->fs_ipg);
854 1.64 bouyer cgp->cg_cs.cs_nifree++;
855 1.64 bouyer sblock->fs_cstotal.cs_nifree++;
856 1.64 bouyer sblock->fs_cs(fs, cg).cs_nifree++;
857 1.64 bouyer sbdirty();
858 1.64 bouyer cgdirty();
859 1.64 bouyer }
860 1.64 bouyer }
861 1.64 bouyer
862 1.64 bouyer /* read a data block from inode */
863 1.64 bouyer ssize_t
864 1.64 bouyer readblk(union dinode *dp, off_t offset, struct bufarea **bp)
865 1.64 bouyer {
866 1.64 bouyer daddr_t blkno = lblkno(sblock, offset);
867 1.64 bouyer daddr_t iblkno;
868 1.64 bouyer int type = IFMT & iswap16(DIP(dp, mode));
869 1.64 bouyer ssize_t filesize = iswap64(DIP(dp, size));
870 1.64 bouyer int ilevel;
871 1.64 bouyer daddr_t nblks;
872 1.64 bouyer const daddr_t naddrperblk = sblock->fs_bsize /
873 1.64 bouyer (is_ufs2 ? sizeof(uint64_t) : sizeof(uint32_t));
874 1.64 bouyer struct bufarea *ibp;
875 1.64 bouyer
876 1.64 bouyer *bp = NULL;
877 1.64 bouyer offset &= ~(sblock->fs_bsize - 1);
878 1.64 bouyer
879 1.64 bouyer if (type != IFREG)
880 1.64 bouyer return 0;
881 1.64 bouyer if (offset >= filesize)
882 1.64 bouyer return 0; /* short read */
883 1.65 dholland if (blkno < UFS_NDADDR) {
884 1.64 bouyer blkno = is_ufs2 ? iswap64(dp->dp2.di_db[blkno]) :
885 1.64 bouyer iswap32(dp->dp1.di_db[blkno]);
886 1.64 bouyer if (blkno == 0)
887 1.64 bouyer return 0;
888 1.64 bouyer *bp = getdatablk(blkno, sblock->fs_bsize);
889 1.64 bouyer return (bp != NULL) ? sblock->fs_bsize : 0;
890 1.64 bouyer }
891 1.65 dholland blkno -= UFS_NDADDR;
892 1.64 bouyer /* find indir level */
893 1.64 bouyer for (ilevel = 1, nblks = naddrperblk;
894 1.65 dholland ilevel <= UFS_NIADDR;
895 1.64 bouyer ilevel++, nblks *= naddrperblk) {
896 1.64 bouyer if (blkno < nblks)
897 1.64 bouyer break;
898 1.64 bouyer else
899 1.64 bouyer blkno -= nblks;
900 1.64 bouyer }
901 1.65 dholland if (ilevel > UFS_NIADDR)
902 1.64 bouyer errexit("bad ofsset %" PRIu64 " to readblk", offset);
903 1.64 bouyer
904 1.64 bouyer /* get the first indirect block */
905 1.64 bouyer iblkno = is_ufs2 ? iswap64(dp->dp2.di_ib[ilevel - 1]) :
906 1.64 bouyer iswap32(dp->dp1.di_ib[ilevel - 1]);
907 1.64 bouyer if (iblkno == 0)
908 1.64 bouyer return 0;
909 1.64 bouyer ibp = getdatablk(iblkno, sblock->fs_bsize);
910 1.64 bouyer /* walk indirect blocks up to the data block */
911 1.64 bouyer for (; ilevel >0 ; ilevel--) {
912 1.64 bouyer nblks = nblks / naddrperblk;
913 1.64 bouyer if (is_ufs2)
914 1.64 bouyer iblkno = iswap64(ibp->b_un.b_indir2[blkno / nblks]);
915 1.64 bouyer else
916 1.64 bouyer iblkno = iswap32(ibp->b_un.b_indir1[blkno / nblks]);
917 1.64 bouyer if (iblkno == 0)
918 1.64 bouyer return 0;
919 1.64 bouyer blkno = blkno % nblks;
920 1.64 bouyer ibp->b_flags &= ~B_INUSE;
921 1.64 bouyer ibp = getdatablk(iblkno, sblock->fs_bsize);
922 1.64 bouyer }
923 1.64 bouyer *bp = ibp;
924 1.64 bouyer return sblock->fs_bsize;
925 1.64 bouyer }
926 1.64 bouyer
927 1.64 bouyer static struct bufarea * getnewblk(daddr_t *);
928 1.64 bouyer static struct bufarea *
929 1.64 bouyer getnewblk(daddr_t *blkno)
930 1.64 bouyer {
931 1.64 bouyer struct bufarea *bp;
932 1.64 bouyer *blkno = allocblk(sblock->fs_frag);
933 1.64 bouyer if (*blkno == 0)
934 1.64 bouyer return NULL;
935 1.64 bouyer bp = getdatablk(*blkno, sblock->fs_bsize);
936 1.64 bouyer memset(bp->b_un.b_buf, 0, sblock->fs_bsize);
937 1.64 bouyer return bp;
938 1.64 bouyer }
939 1.64 bouyer
940 1.64 bouyer /* expand given inode by one full fs block */
941 1.64 bouyer struct bufarea *
942 1.64 bouyer expandfile(union dinode *dp)
943 1.64 bouyer {
944 1.64 bouyer uint64_t filesize = iswap64(DIP(dp, size));
945 1.64 bouyer daddr_t newblk, blkno, iblkno, nblks;
946 1.64 bouyer daddr_t di_blocks;
947 1.64 bouyer int ilevel;
948 1.64 bouyer const daddr_t naddrperblk = sblock->fs_bsize /
949 1.64 bouyer (is_ufs2 ? sizeof(uint64_t) : sizeof(uint32_t));
950 1.64 bouyer struct bufarea *ibp, *bp = NULL;
951 1.64 bouyer
952 1.64 bouyer di_blocks = is_ufs2 ? iswap64(dp->dp2.di_blocks) :
953 1.64 bouyer iswap32(dp->dp1.di_blocks);
954 1.64 bouyer /* compute location of new block */
955 1.64 bouyer blkno = lblkno(sblock, filesize);
956 1.64 bouyer
957 1.65 dholland if (blkno < UFS_NDADDR) {
958 1.64 bouyer /* easy way: allocate a direct block */
959 1.64 bouyer if ((bp = getnewblk(&newblk)) == NULL) {
960 1.64 bouyer return NULL;
961 1.64 bouyer }
962 1.64 bouyer di_blocks += btodb(sblock->fs_bsize);
963 1.64 bouyer
964 1.64 bouyer if (is_ufs2) {
965 1.64 bouyer dp->dp2.di_db[blkno] = iswap64(newblk);
966 1.64 bouyer } else {
967 1.64 bouyer dp->dp1.di_db[blkno] = iswap32(newblk);
968 1.64 bouyer }
969 1.64 bouyer goto out;
970 1.64 bouyer }
971 1.65 dholland blkno -= UFS_NDADDR;
972 1.64 bouyer /* find indir level */
973 1.64 bouyer for (ilevel = 1, nblks = naddrperblk;
974 1.65 dholland ilevel <= UFS_NIADDR;
975 1.64 bouyer ilevel++, nblks *= naddrperblk) {
976 1.64 bouyer if (blkno < nblks)
977 1.64 bouyer break;
978 1.64 bouyer else
979 1.64 bouyer blkno -= nblks;
980 1.64 bouyer }
981 1.65 dholland if (ilevel > UFS_NIADDR)
982 1.64 bouyer errexit("bad filesize %" PRIu64 " to expandfile", filesize);
983 1.64 bouyer
984 1.64 bouyer /* get the first indirect block, allocating if needed */
985 1.64 bouyer if ((is_ufs2 ? iswap64(dp->dp2.di_ib[ilevel - 1]) :
986 1.64 bouyer iswap32(dp->dp1.di_ib[ilevel - 1])) == 0) {
987 1.64 bouyer if ((ibp = getnewblk(&newblk)) == NULL)
988 1.64 bouyer return 0;
989 1.64 bouyer di_blocks += btodb(sblock->fs_bsize);
990 1.64 bouyer if (is_ufs2)
991 1.64 bouyer dp->dp2.di_ib[ilevel - 1] = iswap64(newblk);
992 1.64 bouyer else
993 1.64 bouyer dp->dp1.di_ib[ilevel - 1] = iswap32(newblk);
994 1.64 bouyer } else {
995 1.64 bouyer ibp = getdatablk(is_ufs2 ? iswap64(dp->dp2.di_ib[ilevel - 1]) :
996 1.64 bouyer iswap32(dp->dp2.di_ib[ilevel - 1]), sblock->fs_bsize);
997 1.64 bouyer }
998 1.64 bouyer /* walk indirect blocks up to the data block */
999 1.64 bouyer for (; ilevel >0 ; ilevel--) {
1000 1.64 bouyer nblks = nblks / naddrperblk;
1001 1.64 bouyer if (is_ufs2)
1002 1.64 bouyer iblkno = iswap64(ibp->b_un.b_indir2[blkno / nblks]);
1003 1.64 bouyer else
1004 1.64 bouyer iblkno = iswap32(ibp->b_un.b_indir1[blkno / nblks]);
1005 1.64 bouyer if (iblkno == 0) {
1006 1.64 bouyer if ((bp = getnewblk(&newblk)) == NULL)
1007 1.64 bouyer return NULL;
1008 1.64 bouyer di_blocks += btodb(sblock->fs_bsize);
1009 1.64 bouyer if (is_ufs2)
1010 1.64 bouyer ibp->b_un.b_indir2[blkno / nblks] =
1011 1.64 bouyer iswap64(newblk);
1012 1.64 bouyer else
1013 1.64 bouyer ibp->b_un.b_indir1[blkno / nblks] =
1014 1.64 bouyer iswap32(newblk);
1015 1.64 bouyer dirty(ibp);
1016 1.64 bouyer ibp->b_flags &= ~B_INUSE;
1017 1.64 bouyer ibp = bp;
1018 1.64 bouyer } else {
1019 1.64 bouyer ibp->b_flags &= ~B_INUSE;
1020 1.64 bouyer ibp = getdatablk(iblkno, sblock->fs_bsize);
1021 1.64 bouyer bp = NULL;
1022 1.64 bouyer }
1023 1.64 bouyer blkno = blkno % nblks;
1024 1.64 bouyer }
1025 1.64 bouyer if (bp == NULL) {
1026 1.64 bouyer errexit("INTERNAL ERROR: "
1027 1.64 bouyer "expandfile() failed to allocate a new block\n");
1028 1.64 bouyer }
1029 1.64 bouyer
1030 1.64 bouyer out:
1031 1.64 bouyer filesize += sblock->fs_bsize;
1032 1.64 bouyer if (is_ufs2) {
1033 1.64 bouyer dp->dp2.di_size = iswap64(filesize);
1034 1.64 bouyer dp->dp2.di_blocks = iswap64(di_blocks);
1035 1.64 bouyer } else {
1036 1.64 bouyer dp->dp1.di_size = iswap64(filesize);
1037 1.64 bouyer dp->dp1.di_blocks = iswap32(di_blocks);
1038 1.64 bouyer }
1039 1.64 bouyer inodirty();
1040 1.64 bouyer return bp;
1041 1.1 cgd }
1042