utilities.c revision 1.70 1 1.70 riastrad /* $NetBSD: utilities.c,v 1.70 2023/07/04 20:40:53 riastradh Exp $ */
2 1.15 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.41 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.19 lukem #include <sys/cdefs.h>
33 1.1 cgd #ifndef lint
34 1.13 cgd #if 0
35 1.20 lukem static char sccsid[] = "@(#)utilities.c 8.6 (Berkeley) 5/19/95";
36 1.13 cgd #else
37 1.70 riastrad __RCSID("$NetBSD: utilities.c,v 1.70 2023/07/04 20:40:53 riastradh 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.20 lukem
44 1.9 mycroft #include <ufs/ufs/dinode.h>
45 1.9 mycroft #include <ufs/ufs/dir.h>
46 1.9 mycroft #include <ufs/ffs/fs.h>
47 1.23 bouyer #include <ufs/ffs/ffs_extern.h>
48 1.26 fvdl #include <ufs/ufs/ufs_bswap.h>
49 1.59 bouyer #include <ufs/ufs/quota2.h>
50 1.20 lukem
51 1.20 lukem #include <ctype.h>
52 1.20 lukem #include <err.h>
53 1.38 yamt #include <errno.h>
54 1.21 lukem #include <stdio.h>
55 1.21 lukem #include <stdlib.h>
56 1.1 cgd #include <string.h>
57 1.21 lukem #include <unistd.h>
58 1.54 drochner #include <signal.h>
59 1.11 cgd
60 1.18 christos #include "fsutil.h"
61 1.1 cgd #include "fsck.h"
62 1.11 cgd #include "extern.h"
63 1.55 christos #include "exitvalues.h"
64 1.1 cgd
65 1.1 cgd long diskreads, totalreads; /* Disk cache statistics */
66 1.1 cgd
67 1.50 christos static void rwerror(const char *, daddr_t);
68 1.17 christos
69 1.11 cgd int
70 1.48 xtraeme ftypeok(union dinode *dp)
71 1.1 cgd {
72 1.36 fvdl switch (iswap16(DIP(dp, mode)) & IFMT) {
73 1.1 cgd
74 1.1 cgd case IFDIR:
75 1.1 cgd case IFREG:
76 1.1 cgd case IFBLK:
77 1.1 cgd case IFCHR:
78 1.1 cgd case IFLNK:
79 1.1 cgd case IFSOCK:
80 1.1 cgd case IFIFO:
81 1.1 cgd return (1);
82 1.1 cgd
83 1.1 cgd default:
84 1.1 cgd if (debug)
85 1.36 fvdl printf("bad file type 0%o\n", iswap16(DIP(dp, mode)));
86 1.1 cgd return (0);
87 1.1 cgd }
88 1.1 cgd }
89 1.1 cgd
90 1.11 cgd int
91 1.50 christos reply(const char *question)
92 1.1 cgd {
93 1.1 cgd int persevere;
94 1.1 cgd char c;
95 1.1 cgd
96 1.1 cgd if (preen)
97 1.1 cgd pfatal("INTERNAL ERROR: GOT TO reply()");
98 1.1 cgd persevere = !strcmp(question, "CONTINUE");
99 1.1 cgd printf("\n");
100 1.1 cgd if (!persevere && (nflag || fswritefd < 0)) {
101 1.1 cgd printf("%s? no\n\n", question);
102 1.26 fvdl resolved = 0;
103 1.1 cgd return (0);
104 1.1 cgd }
105 1.1 cgd if (yflag || (persevere && nflag)) {
106 1.1 cgd printf("%s? yes\n\n", question);
107 1.1 cgd return (1);
108 1.1 cgd }
109 1.1 cgd do {
110 1.1 cgd printf("%s? [yn] ", question);
111 1.1 cgd (void) fflush(stdout);
112 1.1 cgd c = getc(stdin);
113 1.26 fvdl while (c != '\n' && getc(stdin) != '\n') {
114 1.26 fvdl if (feof(stdin)) {
115 1.26 fvdl resolved = 0;
116 1.1 cgd return (0);
117 1.26 fvdl }
118 1.26 fvdl }
119 1.1 cgd } while (c != 'y' && c != 'Y' && c != 'n' && c != 'N');
120 1.1 cgd printf("\n");
121 1.1 cgd if (c == 'y' || c == 'Y')
122 1.1 cgd return (1);
123 1.26 fvdl resolved = 0;
124 1.1 cgd return (0);
125 1.1 cgd }
126 1.1 cgd
127 1.1 cgd /*
128 1.1 cgd * Malloc buffers and set up cache.
129 1.1 cgd */
130 1.11 cgd void
131 1.48 xtraeme bufinit(void)
132 1.1 cgd {
133 1.19 lukem struct bufarea *bp;
134 1.1 cgd long bufcnt, i;
135 1.1 cgd char *bufp;
136 1.1 cgd
137 1.1 cgd pbp = pdirbp = (struct bufarea *)0;
138 1.69 riastrad __CTASSERT(powerof2(DEV_BSIZE));
139 1.69 riastrad bufp = aligned_alloc(DEV_BSIZE,
140 1.69 riastrad roundup2((unsigned int)sblock->fs_bsize, DEV_BSIZE));
141 1.1 cgd if (bufp == 0)
142 1.55 christos errexit("cannot allocate buffer pool");
143 1.1 cgd cgblk.b_un.b_buf = bufp;
144 1.1 cgd initbarea(&cgblk);
145 1.65 rin #ifndef NO_APPLE_UFS
146 1.69 riastrad __CTASSERT((APPLEUFS_LABEL_SIZE % DEV_BSIZE) == 0);
147 1.66 jdolecek bufp = aligned_alloc(DEV_BSIZE, (unsigned int)APPLEUFS_LABEL_SIZE);
148 1.34 dbj if (bufp == 0)
149 1.55 christos errexit("cannot allocate buffer pool");
150 1.34 dbj appleufsblk.b_un.b_buf = bufp;
151 1.34 dbj initbarea(&appleufsblk);
152 1.65 rin #endif
153 1.1 cgd bufhead.b_next = bufhead.b_prev = &bufhead;
154 1.23 bouyer bufcnt = MAXBUFSPACE / sblock->fs_bsize;
155 1.1 cgd if (bufcnt < MINBUFS)
156 1.1 cgd bufcnt = MINBUFS;
157 1.1 cgd for (i = 0; i < bufcnt; i++) {
158 1.53 christos bp = malloc(sizeof(struct bufarea));
159 1.69 riastrad __CTASSERT(powerof2(DEV_BSIZE));
160 1.69 riastrad bufp = aligned_alloc(DEV_BSIZE,
161 1.69 riastrad roundup2((unsigned int)sblock->fs_bsize, DEV_BSIZE));
162 1.1 cgd if (bp == NULL || bufp == NULL) {
163 1.53 christos if (i >= MINBUFS) {
164 1.53 christos if (bp)
165 1.53 christos free(bp);
166 1.53 christos if (bufp)
167 1.53 christos free(bufp);
168 1.1 cgd break;
169 1.53 christos }
170 1.55 christos errexit("cannot allocate buffer pool");
171 1.1 cgd }
172 1.1 cgd bp->b_un.b_buf = bufp;
173 1.1 cgd bp->b_prev = &bufhead;
174 1.1 cgd bp->b_next = bufhead.b_next;
175 1.1 cgd bufhead.b_next->b_prev = bp;
176 1.1 cgd bufhead.b_next = bp;
177 1.1 cgd initbarea(bp);
178 1.1 cgd }
179 1.1 cgd bufhead.b_size = i; /* save number of buffers */
180 1.1 cgd }
181 1.1 cgd
182 1.1 cgd /*
183 1.1 cgd * Manage a cache of directory blocks.
184 1.1 cgd */
185 1.1 cgd struct bufarea *
186 1.48 xtraeme getdatablk(daddr_t blkno, long size)
187 1.1 cgd {
188 1.19 lukem struct bufarea *bp;
189 1.1 cgd
190 1.1 cgd for (bp = bufhead.b_next; bp != &bufhead; bp = bp->b_next)
191 1.62 dholland if (bp->b_bno == FFS_FSBTODB(sblock, blkno))
192 1.1 cgd goto foundit;
193 1.1 cgd for (bp = bufhead.b_prev; bp != &bufhead; bp = bp->b_prev)
194 1.1 cgd if ((bp->b_flags & B_INUSE) == 0)
195 1.1 cgd break;
196 1.1 cgd if (bp == &bufhead)
197 1.55 christos errexit("deadlocked buffer pool");
198 1.1 cgd /* fall through */
199 1.1 cgd foundit:
200 1.42 dbj getblk(bp, blkno, size);
201 1.1 cgd bp->b_prev->b_next = bp->b_next;
202 1.1 cgd bp->b_next->b_prev = bp->b_prev;
203 1.1 cgd bp->b_prev = &bufhead;
204 1.1 cgd bp->b_next = bufhead.b_next;
205 1.1 cgd bufhead.b_next->b_prev = bp;
206 1.1 cgd bufhead.b_next = bp;
207 1.1 cgd bp->b_flags |= B_INUSE;
208 1.1 cgd return (bp);
209 1.1 cgd }
210 1.1 cgd
211 1.1 cgd void
212 1.48 xtraeme getblk(struct bufarea *bp, daddr_t blk, long size)
213 1.1 cgd {
214 1.35 fvdl daddr_t dblk;
215 1.1 cgd
216 1.62 dholland dblk = FFS_FSBTODB(sblock, blk);
217 1.42 dbj totalreads++;
218 1.1 cgd if (bp->b_bno != dblk) {
219 1.1 cgd flush(fswritefd, bp);
220 1.1 cgd diskreads++;
221 1.1 cgd bp->b_errs = bread(fsreadfd, bp->b_un.b_buf, dblk, size);
222 1.1 cgd bp->b_bno = dblk;
223 1.1 cgd bp->b_size = size;
224 1.1 cgd }
225 1.1 cgd }
226 1.1 cgd
227 1.11 cgd void
228 1.48 xtraeme flush(int fd, struct bufarea *bp)
229 1.1 cgd {
230 1.19 lukem int i, j;
231 1.32 lukem struct csum *ccsp;
232 1.1 cgd
233 1.1 cgd if (!bp->b_dirty)
234 1.1 cgd return;
235 1.1 cgd if (bp->b_errs != 0)
236 1.35 fvdl pfatal("WRITING %sZERO'ED BLOCK %lld TO DISK\n",
237 1.1 cgd (bp->b_errs == bp->b_size / dev_bsize) ? "" : "PARTIALLY ",
238 1.35 fvdl (long long)bp->b_bno);
239 1.1 cgd bp->b_dirty = 0;
240 1.1 cgd bp->b_errs = 0;
241 1.1 cgd bwrite(fd, bp->b_un.b_buf, bp->b_bno, (long)bp->b_size);
242 1.1 cgd if (bp != &sblk)
243 1.1 cgd return;
244 1.23 bouyer for (i = 0, j = 0; i < sblock->fs_cssize; i += sblock->fs_bsize, j++) {
245 1.23 bouyer int size = sblock->fs_cssize - i < sblock->fs_bsize ?
246 1.23 bouyer sblock->fs_cssize - i : sblock->fs_bsize;
247 1.32 lukem ccsp = (struct csum *)((char *)sblock->fs_csp + i);
248 1.32 lukem if (needswap)
249 1.32 lukem ffs_csum_swap(ccsp, ccsp, size);
250 1.32 lukem bwrite(fswritefd, (char *)ccsp,
251 1.62 dholland FFS_FSBTODB(sblock, sblock->fs_csaddr + j * sblock->fs_frag),
252 1.29 mycroft size);
253 1.32 lukem if (needswap)
254 1.32 lukem ffs_csum_swap(ccsp, ccsp, size);
255 1.1 cgd }
256 1.1 cgd }
257 1.1 cgd
258 1.17 christos static void
259 1.50 christos rwerror(const char *mesg, daddr_t blk)
260 1.1 cgd {
261 1.1 cgd
262 1.1 cgd if (preen == 0)
263 1.1 cgd printf("\n");
264 1.35 fvdl pfatal("CANNOT %s: BLK %lld", mesg, (long long)blk);
265 1.1 cgd if (reply("CONTINUE") == 0)
266 1.55 christos exit(FSCK_EXIT_CHECK_FAILED);
267 1.1 cgd }
268 1.1 cgd
269 1.11 cgd void
270 1.60 christos ckfini(int noint)
271 1.1 cgd {
272 1.19 lukem struct bufarea *bp, *nbp;
273 1.64 christos int cnt = 0;
274 1.1 cgd
275 1.60 christos if (!noint) {
276 1.60 christos if (doinglevel2)
277 1.60 christos return;
278 1.60 christos markclean = 0;
279 1.60 christos }
280 1.60 christos
281 1.9 mycroft if (fswritefd < 0) {
282 1.9 mycroft (void)close(fsreadfd);
283 1.9 mycroft return;
284 1.9 mycroft }
285 1.1 cgd flush(fswritefd, &sblk);
286 1.39 fvdl if (havesb && bflag != 0 &&
287 1.44 dbj (preen || reply("UPDATE STANDARD SUPERBLOCK"))) {
288 1.44 dbj if (preen)
289 1.45 dbj pwarn("UPDATING STANDARD SUPERBLOCK\n");
290 1.39 fvdl if (!is_ufs2 && (sblock->fs_old_flags & FS_FLAGS_UPDATED) == 0)
291 1.39 fvdl sblk.b_bno = SBLOCK_UFS1 / dev_bsize;
292 1.39 fvdl else
293 1.39 fvdl sblk.b_bno = sblock->fs_sblockloc / dev_bsize;
294 1.1 cgd sbdirty();
295 1.1 cgd flush(fswritefd, &sblk);
296 1.1 cgd }
297 1.65 rin #ifndef NO_APPLE_UFS
298 1.34 dbj flush(fswritefd, &appleufsblk);
299 1.34 dbj free(appleufsblk.b_un.b_buf);
300 1.65 rin #endif
301 1.1 cgd flush(fswritefd, &cgblk);
302 1.1 cgd free(cgblk.b_un.b_buf);
303 1.6 deraadt for (bp = bufhead.b_prev; bp && bp != &bufhead; bp = nbp) {
304 1.1 cgd cnt++;
305 1.1 cgd flush(fswritefd, bp);
306 1.1 cgd nbp = bp->b_prev;
307 1.1 cgd free(bp->b_un.b_buf);
308 1.1 cgd free((char *)bp);
309 1.1 cgd }
310 1.1 cgd if (bufhead.b_size != cnt)
311 1.55 christos errexit("Panic: lost %d buffers", bufhead.b_size - cnt);
312 1.1 cgd pbp = pdirbp = (struct bufarea *)0;
313 1.23 bouyer if (markclean && (sblock->fs_clean & FS_ISCLEAN) == 0) {
314 1.14 mycroft /*
315 1.14 mycroft * Mark the file system as clean, and sync the superblock.
316 1.14 mycroft */
317 1.14 mycroft if (preen)
318 1.14 mycroft pwarn("MARKING FILE SYSTEM CLEAN\n");
319 1.14 mycroft else if (!reply("MARK FILE SYSTEM CLEAN"))
320 1.14 mycroft markclean = 0;
321 1.14 mycroft if (markclean) {
322 1.23 bouyer sblock->fs_clean = FS_ISCLEAN;
323 1.36 fvdl sblock->fs_pendingblocks = 0;
324 1.36 fvdl sblock->fs_pendinginodes = 0;
325 1.14 mycroft sbdirty();
326 1.14 mycroft flush(fswritefd, &sblk);
327 1.20 lukem if (!preen)
328 1.20 lukem printf(
329 1.20 lukem "\n***** FILE SYSTEM MARKED CLEAN *****\n");
330 1.14 mycroft }
331 1.14 mycroft }
332 1.67 chs if (doing2ea) {
333 1.67 chs printf("ENABLING EXTATTR SUPPORT\n");
334 1.67 chs is_ufs2ea = 1;
335 1.67 chs sbdirty();
336 1.67 chs flush(fswritefd, &sblk);
337 1.67 chs }
338 1.67 chs if (doing2noea) {
339 1.67 chs printf("DISABLING EXTATTR SUPPORT\n");
340 1.67 chs is_ufs2ea = 0;
341 1.67 chs sbdirty();
342 1.67 chs flush(fswritefd, &sblk);
343 1.67 chs }
344 1.1 cgd if (debug)
345 1.1 cgd printf("cache missed %ld of %ld (%d%%)\n", diskreads,
346 1.1 cgd totalreads, (int)(diskreads * 100 / totalreads));
347 1.56 simonb cleanup_wapbl();
348 1.1 cgd (void)close(fsreadfd);
349 1.1 cgd (void)close(fswritefd);
350 1.1 cgd }
351 1.1 cgd
352 1.11 cgd int
353 1.48 xtraeme bread(int fd, char *buf, daddr_t blk, long size)
354 1.1 cgd {
355 1.1 cgd char *cp;
356 1.1 cgd int i, errs;
357 1.9 mycroft off_t offset;
358 1.1 cgd
359 1.9 mycroft offset = blk;
360 1.9 mycroft offset *= dev_bsize;
361 1.56 simonb if ((pread(fd, buf, (int)size, offset) == size) &&
362 1.56 simonb read_wapbl(buf, size, blk) == 0)
363 1.1 cgd return (0);
364 1.1 cgd rwerror("READ", blk);
365 1.1 cgd errs = 0;
366 1.10 mycroft memset(buf, 0, (size_t)size);
367 1.1 cgd printf("THE FOLLOWING DISK SECTORS COULD NOT BE READ:");
368 1.1 cgd for (cp = buf, i = 0; i < size; i += secsize, cp += secsize) {
369 1.47 mycroft if (pread(fd, cp, (int)secsize, offset + i) != secsize) {
370 1.1 cgd if (secsize != dev_bsize && dev_bsize != 1)
371 1.35 fvdl printf(" %lld (%lld),",
372 1.35 fvdl (long long)((blk*dev_bsize + i) / secsize),
373 1.35 fvdl (long long)(blk + i / dev_bsize));
374 1.1 cgd else
375 1.35 fvdl printf(" %lld,",
376 1.35 fvdl (long long)(blk + i / dev_bsize));
377 1.1 cgd errs++;
378 1.1 cgd }
379 1.1 cgd }
380 1.1 cgd printf("\n");
381 1.1 cgd return (errs);
382 1.1 cgd }
383 1.1 cgd
384 1.11 cgd void
385 1.48 xtraeme bwrite(int fd, char *buf, daddr_t blk, long size)
386 1.1 cgd {
387 1.1 cgd int i;
388 1.1 cgd char *cp;
389 1.9 mycroft off_t offset;
390 1.1 cgd
391 1.1 cgd if (fd < 0)
392 1.1 cgd return;
393 1.9 mycroft offset = blk;
394 1.9 mycroft offset *= dev_bsize;
395 1.47 mycroft if (pwrite(fd, buf, (int)size, offset) == size) {
396 1.1 cgd fsmodified = 1;
397 1.1 cgd return;
398 1.1 cgd }
399 1.1 cgd rwerror("WRITE", blk);
400 1.1 cgd printf("THE FOLLOWING SECTORS COULD NOT BE WRITTEN:");
401 1.1 cgd for (cp = buf, i = 0; i < size; i += dev_bsize, cp += dev_bsize)
402 1.47 mycroft if (pwrite(fd, cp, (int)dev_bsize, offset + i) != dev_bsize)
403 1.35 fvdl printf(" %lld,", (long long)(blk + i / dev_bsize));
404 1.1 cgd printf("\n");
405 1.1 cgd return;
406 1.1 cgd }
407 1.1 cgd
408 1.1 cgd /*
409 1.1 cgd * allocate a data block with the specified number of fragments
410 1.1 cgd */
411 1.35 fvdl daddr_t
412 1.48 xtraeme allocblk(long frags)
413 1.1 cgd {
414 1.26 fvdl int i, j, k, cg, baseblk;
415 1.26 fvdl struct cg *cgp = cgrp;
416 1.1 cgd
417 1.23 bouyer if (frags <= 0 || frags > sblock->fs_frag)
418 1.1 cgd return (0);
419 1.23 bouyer for (i = 0; i < maxfsblock - sblock->fs_frag; i += sblock->fs_frag) {
420 1.23 bouyer for (j = 0; j <= sblock->fs_frag - frags; j++) {
421 1.1 cgd if (testbmap(i + j))
422 1.1 cgd continue;
423 1.1 cgd for (k = 1; k < frags; k++)
424 1.1 cgd if (testbmap(i + j + k))
425 1.1 cgd break;
426 1.1 cgd if (k < frags) {
427 1.1 cgd j += k;
428 1.1 cgd continue;
429 1.1 cgd }
430 1.26 fvdl cg = dtog(sblock, i + j);
431 1.26 fvdl getblk(&cgblk, cgtod(sblock, cg), sblock->fs_cgsize);
432 1.26 fvdl memcpy(cgp, cgblk.b_un.b_cg, sblock->fs_cgsize);
433 1.26 fvdl if ((doswap && !needswap) || (!doswap && needswap))
434 1.36 fvdl ffs_cg_swap(cgblk.b_un.b_cg, cgp, sblock);
435 1.26 fvdl if (!cg_chkmagic(cgp, 0))
436 1.26 fvdl pfatal("CG %d: ALLOCBLK: BAD MAGIC NUMBER\n",
437 1.26 fvdl cg);
438 1.26 fvdl baseblk = dtogd(sblock, i + j);
439 1.26 fvdl for (k = 0; k < frags; k++) {
440 1.1 cgd setbmap(i + j + k);
441 1.26 fvdl clrbit(cg_blksfree(cgp, 0), baseblk + k);
442 1.26 fvdl }
443 1.1 cgd n_blks += frags;
444 1.59 bouyer if (frags == sblock->fs_frag) {
445 1.26 fvdl cgp->cg_cs.cs_nbfree--;
446 1.59 bouyer sblock->fs_cstotal.cs_nbfree--;
447 1.59 bouyer sblock->fs_cs(fs, cg).cs_nbfree--;
448 1.59 bouyer ffs_clusteracct(sblock, cgp,
449 1.63 dholland ffs_fragstoblks(sblock, baseblk), -1);
450 1.59 bouyer } else {
451 1.26 fvdl cgp->cg_cs.cs_nffree -= frags;
452 1.59 bouyer sblock->fs_cstotal.cs_nffree -= frags;
453 1.59 bouyer sblock->fs_cs(fs, cg).cs_nffree -= frags;
454 1.59 bouyer }
455 1.59 bouyer sbdirty();
456 1.26 fvdl cgdirty();
457 1.1 cgd return (i + j);
458 1.1 cgd }
459 1.1 cgd }
460 1.1 cgd return (0);
461 1.1 cgd }
462 1.1 cgd
463 1.1 cgd /*
464 1.1 cgd * Free a previously allocated block
465 1.1 cgd */
466 1.11 cgd void
467 1.48 xtraeme freeblk(daddr_t blkno, long frags)
468 1.1 cgd {
469 1.1 cgd struct inodesc idesc;
470 1.1 cgd
471 1.59 bouyer memset(&idesc, 0, sizeof(idesc));
472 1.1 cgd idesc.id_blkno = blkno;
473 1.1 cgd idesc.id_numfrags = frags;
474 1.1 cgd (void)pass4check(&idesc);
475 1.1 cgd }
476 1.1 cgd
477 1.1 cgd /*
478 1.1 cgd * Find a pathname
479 1.1 cgd */
480 1.11 cgd void
481 1.48 xtraeme getpathname(char *namebuf, size_t namebuflen, ino_t curdir, ino_t ino)
482 1.1 cgd {
483 1.1 cgd int len;
484 1.19 lukem char *cp;
485 1.1 cgd struct inodesc idesc;
486 1.1 cgd static int busy = 0;
487 1.36 fvdl struct inostat *info;
488 1.1 cgd
489 1.61 dholland if (curdir == ino && ino == UFS_ROOTINO) {
490 1.40 itojun (void)strlcpy(namebuf, "/", namebuflen);
491 1.9 mycroft return;
492 1.9 mycroft }
493 1.36 fvdl info = inoinfo(curdir);
494 1.36 fvdl if (busy || (info->ino_state != DSTATE && info->ino_state != DFOUND)) {
495 1.40 itojun (void)strlcpy(namebuf, "?", namebuflen);
496 1.1 cgd return;
497 1.1 cgd }
498 1.1 cgd busy = 1;
499 1.10 mycroft memset(&idesc, 0, sizeof(struct inodesc));
500 1.1 cgd idesc.id_type = DATA;
501 1.1 cgd idesc.id_fix = IGNORE;
502 1.1 cgd cp = &namebuf[MAXPATHLEN - 1];
503 1.1 cgd *cp = '\0';
504 1.1 cgd if (curdir != ino) {
505 1.1 cgd idesc.id_parent = curdir;
506 1.1 cgd goto namelookup;
507 1.1 cgd }
508 1.61 dholland while (ino != UFS_ROOTINO) {
509 1.1 cgd idesc.id_number = ino;
510 1.1 cgd idesc.id_func = findino;
511 1.1 cgd idesc.id_name = "..";
512 1.1 cgd if ((ckinode(ginode(ino), &idesc) & FOUND) == 0)
513 1.1 cgd break;
514 1.1 cgd namelookup:
515 1.1 cgd idesc.id_number = idesc.id_parent;
516 1.1 cgd idesc.id_parent = ino;
517 1.1 cgd idesc.id_func = findname;
518 1.1 cgd idesc.id_name = namebuf;
519 1.1 cgd if ((ckinode(ginode(idesc.id_number), &idesc)&FOUND) == 0)
520 1.1 cgd break;
521 1.1 cgd len = strlen(namebuf);
522 1.1 cgd cp -= len;
523 1.20 lukem memmove(cp, namebuf, (size_t)len);
524 1.1 cgd *--cp = '/';
525 1.52 tron if (cp < &namebuf[FFS_MAXNAMLEN])
526 1.1 cgd break;
527 1.1 cgd ino = idesc.id_number;
528 1.1 cgd }
529 1.1 cgd busy = 0;
530 1.61 dholland if (ino != UFS_ROOTINO)
531 1.1 cgd *--cp = '?';
532 1.20 lukem memmove(namebuf, cp, (size_t)(&namebuf[MAXPATHLEN] - cp));
533 1.1 cgd }
534 1.1 cgd
535 1.1 cgd /*
536 1.1 cgd * determine whether an inode should be fixed.
537 1.1 cgd */
538 1.11 cgd int
539 1.50 christos dofix(struct inodesc *idesc, const char *msg)
540 1.1 cgd {
541 1.1 cgd
542 1.1 cgd switch (idesc->id_fix) {
543 1.1 cgd
544 1.1 cgd case DONTKNOW:
545 1.1 cgd if (idesc->id_type == DATA)
546 1.1 cgd direrror(idesc->id_number, msg);
547 1.1 cgd else
548 1.27 is pwarn("%s", msg);
549 1.1 cgd if (preen) {
550 1.1 cgd printf(" (SALVAGED)\n");
551 1.1 cgd idesc->id_fix = FIX;
552 1.1 cgd return (ALTERED);
553 1.1 cgd }
554 1.1 cgd if (reply("SALVAGE") == 0) {
555 1.1 cgd idesc->id_fix = NOFIX;
556 1.1 cgd return (0);
557 1.1 cgd }
558 1.1 cgd idesc->id_fix = FIX;
559 1.1 cgd return (ALTERED);
560 1.1 cgd
561 1.1 cgd case FIX:
562 1.1 cgd return (ALTERED);
563 1.1 cgd
564 1.1 cgd case NOFIX:
565 1.1 cgd case IGNORE:
566 1.1 cgd return (0);
567 1.1 cgd
568 1.1 cgd default:
569 1.55 christos errexit("UNKNOWN INODESC FIX MODE %d", idesc->id_fix);
570 1.1 cgd }
571 1.1 cgd /* NOTREACHED */
572 1.20 lukem return (0);
573 1.23 bouyer }
574 1.23 bouyer
575 1.25 mycroft void
576 1.48 xtraeme copyback_cg(struct bufarea *blk)
577 1.23 bouyer {
578 1.25 mycroft
579 1.25 mycroft memcpy(blk->b_un.b_cg, cgrp, sblock->fs_cgsize);
580 1.23 bouyer if (needswap)
581 1.36 fvdl ffs_cg_swap(cgrp, blk->b_un.b_cg, sblock);
582 1.23 bouyer }
583 1.23 bouyer
584 1.23 bouyer void
585 1.36 fvdl infohandler(int sig)
586 1.23 bouyer {
587 1.36 fvdl got_siginfo = 1;
588 1.1 cgd }
589 1.33 lukem
590 1.36 fvdl /*
591 1.36 fvdl * Look up state information for an inode.
592 1.36 fvdl */
593 1.36 fvdl struct inostat *
594 1.36 fvdl inoinfo(ino_t inum)
595 1.33 lukem {
596 1.36 fvdl static struct inostat unallocated = { USTATE, 0, 0 };
597 1.36 fvdl struct inostatlist *ilp;
598 1.68 christos size_t iloff;
599 1.36 fvdl
600 1.36 fvdl if (inum > maxino)
601 1.55 christos errexit("inoinfo: inumber %llu out of range",
602 1.51 christos (unsigned long long)inum);
603 1.36 fvdl ilp = &inostathead[inum / sblock->fs_ipg];
604 1.36 fvdl iloff = inum % sblock->fs_ipg;
605 1.36 fvdl if (iloff >= ilp->il_numalloced)
606 1.36 fvdl return (&unallocated);
607 1.36 fvdl return (&ilp->il_stat[iloff]);
608 1.37 fvdl }
609 1.37 fvdl
610 1.37 fvdl void
611 1.43 dbj sb_oldfscompat_read(struct fs *fs, struct fs **fssave)
612 1.37 fvdl {
613 1.43 dbj if ((fs->fs_magic != FS_UFS1_MAGIC) ||
614 1.43 dbj (fs->fs_old_flags & FS_FLAGS_UPDATED))
615 1.37 fvdl return;
616 1.37 fvdl
617 1.43 dbj /* Save a copy of fields that may be modified for compatibility */
618 1.43 dbj if (fssave) {
619 1.43 dbj if (!*fssave)
620 1.43 dbj *fssave = malloc(sizeof(struct fs));
621 1.43 dbj if (!*fssave)
622 1.55 christos errexit("cannot allocate space for compat store");
623 1.43 dbj memmove(*fssave, fs, sizeof(struct fs));
624 1.43 dbj
625 1.43 dbj if (debug)
626 1.43 dbj printf("detected ufs1 superblock not yet updated for ufs2 kernels\n");
627 1.43 dbj
628 1.43 dbj if (doswap) {
629 1.43 dbj uint16_t postbl[256];
630 1.43 dbj int i, n;
631 1.43 dbj
632 1.43 dbj if (fs->fs_old_postblformat == FS_42POSTBLFMT)
633 1.43 dbj n = 256;
634 1.43 dbj else
635 1.43 dbj n = 128;
636 1.43 dbj
637 1.43 dbj /* extract the postbl from the unswapped superblock */
638 1.43 dbj if (!needswap)
639 1.43 dbj ffs_sb_swap(*fssave, *fssave);
640 1.46 dbj memmove(postbl, (&(*fssave)->fs_old_postbl_start),
641 1.46 dbj n * sizeof(postbl[0]));
642 1.43 dbj if (!needswap)
643 1.43 dbj ffs_sb_swap(*fssave, *fssave);
644 1.43 dbj
645 1.43 dbj /* Now swap it */
646 1.43 dbj for (i=0; i < n; i++)
647 1.43 dbj postbl[i] = bswap16(postbl[i]);
648 1.43 dbj
649 1.43 dbj /* And put it back such that it will get correctly
650 1.43 dbj * unscrambled if it is swapped again on the way out
651 1.43 dbj */
652 1.43 dbj if (needswap)
653 1.43 dbj ffs_sb_swap(*fssave, *fssave);
654 1.46 dbj memmove((&(*fssave)->fs_old_postbl_start), postbl,
655 1.46 dbj n * sizeof(postbl[0]));
656 1.43 dbj if (needswap)
657 1.43 dbj ffs_sb_swap(*fssave, *fssave);
658 1.43 dbj }
659 1.43 dbj
660 1.43 dbj }
661 1.43 dbj
662 1.43 dbj /* These fields will be overwritten by their
663 1.43 dbj * original values in fs_oldfscompat_write, so it is harmless
664 1.43 dbj * to modify them here.
665 1.43 dbj */
666 1.43 dbj fs->fs_cstotal.cs_ndir =
667 1.43 dbj fs->fs_old_cstotal.cs_ndir;
668 1.43 dbj fs->fs_cstotal.cs_nbfree =
669 1.43 dbj fs->fs_old_cstotal.cs_nbfree;
670 1.43 dbj fs->fs_cstotal.cs_nifree =
671 1.43 dbj fs->fs_old_cstotal.cs_nifree;
672 1.43 dbj fs->fs_cstotal.cs_nffree =
673 1.43 dbj fs->fs_old_cstotal.cs_nffree;
674 1.70 riastrad
675 1.43 dbj fs->fs_maxbsize = fs->fs_bsize;
676 1.43 dbj fs->fs_time = fs->fs_old_time;
677 1.43 dbj fs->fs_size = fs->fs_old_size;
678 1.43 dbj fs->fs_dsize = fs->fs_old_dsize;
679 1.43 dbj fs->fs_csaddr = fs->fs_old_csaddr;
680 1.43 dbj fs->fs_sblockloc = SBLOCK_UFS1;
681 1.43 dbj
682 1.43 dbj fs->fs_flags = fs->fs_old_flags;
683 1.43 dbj
684 1.43 dbj if (fs->fs_old_postblformat == FS_42POSTBLFMT) {
685 1.43 dbj fs->fs_old_nrpos = 8;
686 1.43 dbj fs->fs_old_npsect = fs->fs_old_nsect;
687 1.43 dbj fs->fs_old_interleave = 1;
688 1.43 dbj fs->fs_old_trackskew = 0;
689 1.43 dbj }
690 1.43 dbj }
691 1.43 dbj
692 1.43 dbj void
693 1.43 dbj sb_oldfscompat_write(struct fs *fs, struct fs *fssave)
694 1.43 dbj {
695 1.43 dbj if ((fs->fs_magic != FS_UFS1_MAGIC) ||
696 1.43 dbj (fs->fs_old_flags & FS_FLAGS_UPDATED))
697 1.43 dbj return;
698 1.43 dbj
699 1.43 dbj fs->fs_old_flags = fs->fs_flags;
700 1.37 fvdl fs->fs_old_time = fs->fs_time;
701 1.37 fvdl fs->fs_old_cstotal.cs_ndir = fs->fs_cstotal.cs_ndir;
702 1.37 fvdl fs->fs_old_cstotal.cs_nbfree = fs->fs_cstotal.cs_nbfree;
703 1.37 fvdl fs->fs_old_cstotal.cs_nifree = fs->fs_cstotal.cs_nifree;
704 1.37 fvdl fs->fs_old_cstotal.cs_nffree = fs->fs_cstotal.cs_nffree;
705 1.43 dbj
706 1.43 dbj fs->fs_flags = fssave->fs_flags;
707 1.43 dbj
708 1.43 dbj if (fs->fs_old_postblformat == FS_42POSTBLFMT) {
709 1.43 dbj fs->fs_old_nrpos = fssave->fs_old_nrpos;
710 1.43 dbj fs->fs_old_npsect = fssave->fs_old_npsect;
711 1.43 dbj fs->fs_old_interleave = fssave->fs_old_interleave;
712 1.43 dbj fs->fs_old_trackskew = fssave->fs_old_trackskew;
713 1.43 dbj }
714 1.43 dbj
715 1.43 dbj memmove(&fs->fs_old_postbl_start, &fssave->fs_old_postbl_start,
716 1.43 dbj ((fs->fs_old_postblformat == FS_42POSTBLFMT) ?
717 1.43 dbj 512 : 256));
718 1.33 lukem }
719 1.59 bouyer
720 1.59 bouyer struct uquot *
721 1.59 bouyer find_uquot(struct uquot_hash *uq_hash, uint32_t uid, int alloc)
722 1.59 bouyer {
723 1.59 bouyer struct uquot *uq;
724 1.59 bouyer SLIST_FOREACH(uq, &uq_hash[uid & q2h_hash_mask], uq_entries) {
725 1.59 bouyer if (uq->uq_uid == uid)
726 1.59 bouyer return uq;
727 1.59 bouyer }
728 1.59 bouyer if (!alloc)
729 1.59 bouyer return NULL;
730 1.59 bouyer uq = malloc(sizeof(struct uquot));
731 1.59 bouyer if (uq == NULL)
732 1.59 bouyer errexit("cannot allocate quota entry");
733 1.59 bouyer memset(uq, 0, sizeof(struct uquot));
734 1.59 bouyer uq->uq_uid = uid;
735 1.59 bouyer SLIST_INSERT_HEAD(&uq_hash[uid & q2h_hash_mask], uq, uq_entries);
736 1.59 bouyer return uq;
737 1.59 bouyer }
738 1.59 bouyer
739 1.59 bouyer void
740 1.59 bouyer remove_uquot(struct uquot_hash *uq_hash, struct uquot *uq)
741 1.59 bouyer {
742 1.59 bouyer SLIST_REMOVE(&uq_hash[uq->uq_uid & q2h_hash_mask],
743 1.59 bouyer uq, uquot, uq_entries);
744 1.59 bouyer }
745 1.59 bouyer
746 1.59 bouyer void
747 1.59 bouyer update_uquot(ino_t inum, uid_t uid, gid_t gid, int64_t bchange, int64_t ichange)
748 1.59 bouyer {
749 1.59 bouyer /* simple uquot cache: remember the last used */
750 1.59 bouyer static struct uquot *uq_u = NULL;
751 1.59 bouyer static struct uquot *uq_g = NULL;
752 1.59 bouyer
753 1.61 dholland if (inum < UFS_ROOTINO)
754 1.59 bouyer return;
755 1.59 bouyer if (is_journal_inode(inum))
756 1.59 bouyer return;
757 1.59 bouyer if (is_quota_inode(inum))
758 1.59 bouyer return;
759 1.70 riastrad
760 1.59 bouyer if (uquot_user_hash == NULL)
761 1.59 bouyer return;
762 1.70 riastrad
763 1.59 bouyer if (uq_u == NULL || uq_u->uq_uid != uid)
764 1.59 bouyer uq_u = find_uquot(uquot_user_hash, uid, 1);
765 1.59 bouyer uq_u->uq_b += bchange;
766 1.59 bouyer uq_u->uq_i += ichange;
767 1.59 bouyer if (uq_g == NULL || uq_g->uq_uid != gid)
768 1.59 bouyer uq_g = find_uquot(uquot_group_hash, gid, 1);
769 1.70 riastrad uq_g->uq_b += bchange;
770 1.59 bouyer uq_g->uq_i += ichange;
771 1.59 bouyer }
772 1.59 bouyer
773 1.59 bouyer int
774 1.59 bouyer is_quota_inode(ino_t inum)
775 1.59 bouyer {
776 1.59 bouyer
777 1.59 bouyer if ((sblock->fs_flags & FS_DOQUOTA2) == 0)
778 1.59 bouyer return 0;
779 1.59 bouyer
780 1.59 bouyer if (sblock->fs_quota_magic != Q2_HEAD_MAGIC)
781 1.59 bouyer return 0;
782 1.70 riastrad
783 1.59 bouyer if (sblock->fs_quotafile[USRQUOTA] == inum)
784 1.59 bouyer return 1;
785 1.59 bouyer
786 1.70 riastrad if (sblock->fs_quotafile[GRPQUOTA] == inum)
787 1.59 bouyer return 1;
788 1.59 bouyer
789 1.59 bouyer return 0;
790 1.59 bouyer }
791