quota_oldfiles.c revision 1.9.2.2 1 1.9.2.2 yamt /* $NetBSD: quota_oldfiles.c,v 1.9.2.2 2012/04/17 00:05:32 yamt Exp $ */
2 1.9.2.2 yamt
3 1.9.2.2 yamt /*
4 1.9.2.2 yamt * Copyright (c) 1980, 1990, 1993
5 1.9.2.2 yamt * The Regents of the University of California. All rights reserved.
6 1.9.2.2 yamt *
7 1.9.2.2 yamt * This code is derived from software contributed to Berkeley by
8 1.9.2.2 yamt * Robert Elz at The University of Melbourne.
9 1.9.2.2 yamt *
10 1.9.2.2 yamt * Redistribution and use in source and binary forms, with or without
11 1.9.2.2 yamt * modification, are permitted provided that the following conditions
12 1.9.2.2 yamt * are met:
13 1.9.2.2 yamt * 1. Redistributions of source code must retain the above copyright
14 1.9.2.2 yamt * notice, this list of conditions and the following disclaimer.
15 1.9.2.2 yamt * 2. Redistributions in binary form must reproduce the above copyright
16 1.9.2.2 yamt * notice, this list of conditions and the following disclaimer in the
17 1.9.2.2 yamt * documentation and/or other materials provided with the distribution.
18 1.9.2.2 yamt * 3. Neither the name of the University nor the names of its contributors
19 1.9.2.2 yamt * may be used to endorse or promote products derived from this software
20 1.9.2.2 yamt * without specific prior written permission.
21 1.9.2.2 yamt *
22 1.9.2.2 yamt * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
23 1.9.2.2 yamt * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
24 1.9.2.2 yamt * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
25 1.9.2.2 yamt * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
26 1.9.2.2 yamt * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
27 1.9.2.2 yamt * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
28 1.9.2.2 yamt * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
29 1.9.2.2 yamt * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
30 1.9.2.2 yamt * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
31 1.9.2.2 yamt * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
32 1.9.2.2 yamt * SUCH DAMAGE.
33 1.9.2.2 yamt */
34 1.9.2.2 yamt
35 1.9.2.2 yamt #include <sys/cdefs.h>
36 1.9.2.2 yamt __RCSID("$NetBSD: quota_oldfiles.c,v 1.9.2.2 2012/04/17 00:05:32 yamt Exp $");
37 1.9.2.2 yamt
38 1.9.2.2 yamt #include <sys/types.h>
39 1.9.2.2 yamt #include <sys/stat.h>
40 1.9.2.2 yamt #include <stdio.h>
41 1.9.2.2 yamt #include <stdlib.h>
42 1.9.2.2 yamt #include <string.h>
43 1.9.2.2 yamt #include <unistd.h>
44 1.9.2.2 yamt #include <fcntl.h>
45 1.9.2.2 yamt #include <limits.h>
46 1.9.2.2 yamt #include <fstab.h>
47 1.9.2.2 yamt #include <errno.h>
48 1.9.2.2 yamt #include <err.h>
49 1.9.2.2 yamt
50 1.9.2.2 yamt #include <ufs/ufs/quota1.h>
51 1.9.2.2 yamt
52 1.9.2.2 yamt #include <quota.h>
53 1.9.2.2 yamt #include "quotapvt.h"
54 1.9.2.2 yamt
55 1.9.2.2 yamt struct oldfiles_fstabentry {
56 1.9.2.2 yamt char *ofe_mountpoint;
57 1.9.2.2 yamt int ofe_hasuserquota;
58 1.9.2.2 yamt int ofe_hasgroupquota;
59 1.9.2.2 yamt char *ofe_userquotafile;
60 1.9.2.2 yamt char *ofe_groupquotafile;
61 1.9.2.2 yamt };
62 1.9.2.2 yamt
63 1.9.2.2 yamt struct oldfiles_quotacursor {
64 1.9.2.2 yamt unsigned oqc_doingusers;
65 1.9.2.2 yamt unsigned oqc_doinggroups;
66 1.9.2.2 yamt
67 1.9.2.2 yamt unsigned oqc_numusers;
68 1.9.2.2 yamt unsigned oqc_numgroups;
69 1.9.2.2 yamt
70 1.9.2.2 yamt unsigned oqc_didusers;
71 1.9.2.2 yamt unsigned oqc_didgroups;
72 1.9.2.2 yamt unsigned oqc_diddefault;
73 1.9.2.2 yamt unsigned oqc_pos;
74 1.9.2.2 yamt unsigned oqc_didblocks;
75 1.9.2.2 yamt };
76 1.9.2.2 yamt
77 1.9.2.2 yamt static struct oldfiles_fstabentry *__quota_oldfiles_fstab;
78 1.9.2.2 yamt static unsigned __quota_oldfiles_numfstab;
79 1.9.2.2 yamt static unsigned __quota_oldfiles_maxfstab;
80 1.9.2.2 yamt static int __quota_oldfiles_fstab_loaded;
81 1.9.2.2 yamt
82 1.9.2.2 yamt static const struct oldfiles_fstabentry *
83 1.9.2.2 yamt __quota_oldfiles_find_fstabentry(const char *mountpoint)
84 1.9.2.2 yamt {
85 1.9.2.2 yamt unsigned i;
86 1.9.2.2 yamt
87 1.9.2.2 yamt for (i = 0; i < __quota_oldfiles_numfstab; i++) {
88 1.9.2.2 yamt if (!strcmp(mountpoint,
89 1.9.2.2 yamt __quota_oldfiles_fstab[i].ofe_mountpoint)) {
90 1.9.2.2 yamt return &__quota_oldfiles_fstab[i];
91 1.9.2.2 yamt }
92 1.9.2.2 yamt }
93 1.9.2.2 yamt return NULL;
94 1.9.2.2 yamt }
95 1.9.2.2 yamt
96 1.9.2.2 yamt static int
97 1.9.2.2 yamt __quota_oldfiles_add_fstabentry(struct oldfiles_fstabentry *ofe)
98 1.9.2.2 yamt {
99 1.9.2.2 yamt unsigned newmax;
100 1.9.2.2 yamt struct oldfiles_fstabentry *newptr;
101 1.9.2.2 yamt
102 1.9.2.2 yamt if (__quota_oldfiles_numfstab + 1 >= __quota_oldfiles_maxfstab) {
103 1.9.2.2 yamt if (__quota_oldfiles_maxfstab == 0) {
104 1.9.2.2 yamt newmax = 4;
105 1.9.2.2 yamt } else {
106 1.9.2.2 yamt newmax = __quota_oldfiles_maxfstab * 2;
107 1.9.2.2 yamt }
108 1.9.2.2 yamt newptr = realloc(__quota_oldfiles_fstab,
109 1.9.2.2 yamt newmax * sizeof(__quota_oldfiles_fstab[0]));
110 1.9.2.2 yamt if (newptr == NULL) {
111 1.9.2.2 yamt return -1;
112 1.9.2.2 yamt }
113 1.9.2.2 yamt __quota_oldfiles_maxfstab = newmax;
114 1.9.2.2 yamt __quota_oldfiles_fstab = newptr;
115 1.9.2.2 yamt }
116 1.9.2.2 yamt
117 1.9.2.2 yamt __quota_oldfiles_fstab[__quota_oldfiles_numfstab++] = *ofe;
118 1.9.2.2 yamt return 0;
119 1.9.2.2 yamt }
120 1.9.2.2 yamt
121 1.9.2.2 yamt static int
122 1.9.2.2 yamt __quota_oldfiles_fill_fstabentry(const struct fstab *fs,
123 1.9.2.2 yamt struct oldfiles_fstabentry *ofe)
124 1.9.2.2 yamt {
125 1.9.2.2 yamt char buf[256];
126 1.9.2.2 yamt char *opt, *state, *s;
127 1.9.2.2 yamt int serrno;
128 1.9.2.2 yamt int ret = 0;
129 1.9.2.2 yamt
130 1.9.2.2 yamt /*
131 1.9.2.2 yamt * Inspect the mount options to find the quota files.
132 1.9.2.2 yamt * XXX this info should be gotten from the kernel.
133 1.9.2.2 yamt *
134 1.9.2.2 yamt * The options are:
135 1.9.2.2 yamt * userquota[=path] enable user quotas
136 1.9.2.2 yamt * groupquota[=path] enable group quotas
137 1.9.2.2 yamt */
138 1.9.2.2 yamt
139 1.9.2.2 yamt ofe->ofe_mountpoint = NULL;
140 1.9.2.2 yamt ofe->ofe_hasuserquota = ofe->ofe_hasgroupquota = 0;
141 1.9.2.2 yamt ofe->ofe_userquotafile = ofe->ofe_groupquotafile = NULL;
142 1.9.2.2 yamt
143 1.9.2.2 yamt strlcpy(buf, fs->fs_mntops, sizeof(buf));
144 1.9.2.2 yamt for (opt = strtok_r(buf, ",", &state);
145 1.9.2.2 yamt opt != NULL;
146 1.9.2.2 yamt opt = strtok_r(NULL, ",", &state)) {
147 1.9.2.2 yamt s = strchr(opt, '=');
148 1.9.2.2 yamt if (s != NULL) {
149 1.9.2.2 yamt *(s++) = '\0';
150 1.9.2.2 yamt }
151 1.9.2.2 yamt if (!strcmp(opt, "userquota")) {
152 1.9.2.2 yamt ret = 1;
153 1.9.2.2 yamt ofe->ofe_hasuserquota = 1;
154 1.9.2.2 yamt if (s != NULL) {
155 1.9.2.2 yamt ofe->ofe_userquotafile = strdup(s);
156 1.9.2.2 yamt if (ofe->ofe_userquotafile == NULL) {
157 1.9.2.2 yamt goto fail;
158 1.9.2.2 yamt }
159 1.9.2.2 yamt }
160 1.9.2.2 yamt } else if (!strcmp(opt, "groupquota")) {
161 1.9.2.2 yamt ret = 1;
162 1.9.2.2 yamt ofe->ofe_hasgroupquota = 1;
163 1.9.2.2 yamt if (s != NULL) {
164 1.9.2.2 yamt ofe->ofe_groupquotafile = strdup(s);
165 1.9.2.2 yamt if (ofe->ofe_groupquotafile == NULL) {
166 1.9.2.2 yamt goto fail;
167 1.9.2.2 yamt }
168 1.9.2.2 yamt }
169 1.9.2.2 yamt }
170 1.9.2.2 yamt }
171 1.9.2.2 yamt
172 1.9.2.2 yamt if (ret == 1) {
173 1.9.2.2 yamt ofe->ofe_mountpoint = strdup(fs->fs_file);
174 1.9.2.2 yamt if (ofe->ofe_mountpoint == NULL) {
175 1.9.2.2 yamt goto fail;
176 1.9.2.2 yamt }
177 1.9.2.2 yamt }
178 1.9.2.2 yamt
179 1.9.2.2 yamt return ret;
180 1.9.2.2 yamt
181 1.9.2.2 yamt fail:
182 1.9.2.2 yamt serrno = errno;
183 1.9.2.2 yamt if (ofe->ofe_mountpoint != NULL) {
184 1.9.2.2 yamt free(ofe->ofe_mountpoint);
185 1.9.2.2 yamt }
186 1.9.2.2 yamt if (ofe->ofe_groupquotafile != NULL) {
187 1.9.2.2 yamt free(ofe->ofe_groupquotafile);
188 1.9.2.2 yamt }
189 1.9.2.2 yamt if (ofe->ofe_userquotafile != NULL) {
190 1.9.2.2 yamt free(ofe->ofe_userquotafile);
191 1.9.2.2 yamt }
192 1.9.2.2 yamt errno = serrno;
193 1.9.2.2 yamt return -1;
194 1.9.2.2 yamt }
195 1.9.2.2 yamt
196 1.9.2.2 yamt void
197 1.9.2.2 yamt __quota_oldfiles_load_fstab(void)
198 1.9.2.2 yamt {
199 1.9.2.2 yamt struct oldfiles_fstabentry ofe;
200 1.9.2.2 yamt struct fstab *fs;
201 1.9.2.2 yamt int result;
202 1.9.2.2 yamt
203 1.9.2.2 yamt if (__quota_oldfiles_fstab_loaded) {
204 1.9.2.2 yamt return;
205 1.9.2.2 yamt }
206 1.9.2.2 yamt
207 1.9.2.2 yamt /*
208 1.9.2.2 yamt * Check if fstab file exists before trying to parse it.
209 1.9.2.2 yamt * Avoid warnings from {get,set}fsent() if missing.
210 1.9.2.2 yamt */
211 1.9.2.2 yamt if (access(_PATH_FSTAB, F_OK) == -1 && errno == ENOENT)
212 1.9.2.2 yamt return;
213 1.9.2.2 yamt
214 1.9.2.2 yamt /*
215 1.9.2.2 yamt * XXX: should be able to handle ext2fs quota1 files too
216 1.9.2.2 yamt *
217 1.9.2.2 yamt * XXX: should use getfsent_r(), but there isn't one.
218 1.9.2.2 yamt */
219 1.9.2.2 yamt setfsent();
220 1.9.2.2 yamt while ((fs = getfsent()) != NULL) {
221 1.9.2.2 yamt if (!strcmp(fs->fs_vfstype, "ffs") ||
222 1.9.2.2 yamt !strcmp(fs->fs_vfstype, "lfs")) {
223 1.9.2.2 yamt result = __quota_oldfiles_fill_fstabentry(fs, &ofe);
224 1.9.2.2 yamt if (result == -1) {
225 1.9.2.2 yamt goto failed;
226 1.9.2.2 yamt }
227 1.9.2.2 yamt if (result == 0) {
228 1.9.2.2 yamt continue;
229 1.9.2.2 yamt }
230 1.9.2.2 yamt if (__quota_oldfiles_add_fstabentry(&ofe)) {
231 1.9.2.2 yamt goto failed;
232 1.9.2.2 yamt }
233 1.9.2.2 yamt }
234 1.9.2.2 yamt }
235 1.9.2.2 yamt endfsent();
236 1.9.2.2 yamt __quota_oldfiles_fstab_loaded = 1;
237 1.9.2.2 yamt
238 1.9.2.2 yamt return;
239 1.9.2.2 yamt failed:
240 1.9.2.2 yamt warn("Failed reading fstab");
241 1.9.2.2 yamt return;
242 1.9.2.2 yamt }
243 1.9.2.2 yamt
244 1.9.2.2 yamt int
245 1.9.2.2 yamt __quota_oldfiles_infstab(const char *mountpoint)
246 1.9.2.2 yamt {
247 1.9.2.2 yamt return __quota_oldfiles_find_fstabentry(mountpoint) != NULL;
248 1.9.2.2 yamt }
249 1.9.2.2 yamt
250 1.9.2.2 yamt static void
251 1.9.2.2 yamt __quota_oldfiles_defquotafile(struct quotahandle *qh, int idtype,
252 1.9.2.2 yamt char *buf, size_t maxlen)
253 1.9.2.2 yamt {
254 1.9.2.2 yamt static const char *const names[] = INITQFNAMES;
255 1.9.2.2 yamt
256 1.9.2.2 yamt (void)snprintf(buf, maxlen, "%s/%s.%s",
257 1.9.2.2 yamt qh->qh_mountpoint,
258 1.9.2.2 yamt QUOTAFILENAME, names[USRQUOTA]);
259 1.9.2.2 yamt }
260 1.9.2.2 yamt
261 1.9.2.2 yamt const char *
262 1.9.2.2 yamt __quota_oldfiles_getquotafile(struct quotahandle *qh, int idtype,
263 1.9.2.2 yamt char *buf, size_t maxlen)
264 1.9.2.2 yamt {
265 1.9.2.2 yamt const struct oldfiles_fstabentry *ofe;
266 1.9.2.2 yamt const char *file;
267 1.9.2.2 yamt
268 1.9.2.2 yamt ofe = __quota_oldfiles_find_fstabentry(qh->qh_mountpoint);
269 1.9.2.2 yamt if (ofe == NULL) {
270 1.9.2.2 yamt errno = ENXIO;
271 1.9.2.2 yamt return NULL;
272 1.9.2.2 yamt }
273 1.9.2.2 yamt
274 1.9.2.2 yamt switch (idtype) {
275 1.9.2.2 yamt case USRQUOTA:
276 1.9.2.2 yamt if (!ofe->ofe_hasuserquota) {
277 1.9.2.2 yamt errno = ENXIO;
278 1.9.2.2 yamt return NULL;
279 1.9.2.2 yamt }
280 1.9.2.2 yamt file = ofe->ofe_userquotafile;
281 1.9.2.2 yamt break;
282 1.9.2.2 yamt case GRPQUOTA:
283 1.9.2.2 yamt if (!ofe->ofe_hasgroupquota) {
284 1.9.2.2 yamt errno = ENXIO;
285 1.9.2.2 yamt return NULL;
286 1.9.2.2 yamt }
287 1.9.2.2 yamt file = ofe->ofe_groupquotafile;
288 1.9.2.2 yamt break;
289 1.9.2.2 yamt default:
290 1.9.2.2 yamt errno = EINVAL;
291 1.9.2.2 yamt return NULL;
292 1.9.2.2 yamt }
293 1.9.2.2 yamt
294 1.9.2.2 yamt if (file == NULL) {
295 1.9.2.2 yamt __quota_oldfiles_defquotafile(qh, idtype, buf, maxlen);
296 1.9.2.2 yamt file = buf;
297 1.9.2.2 yamt }
298 1.9.2.2 yamt return file;
299 1.9.2.2 yamt }
300 1.9.2.2 yamt
301 1.9.2.2 yamt static uint64_t
302 1.9.2.2 yamt dqblk_getlimit(uint32_t val)
303 1.9.2.2 yamt {
304 1.9.2.2 yamt if (val == 0) {
305 1.9.2.2 yamt return QUOTA_NOLIMIT;
306 1.9.2.2 yamt } else {
307 1.9.2.2 yamt return val - 1;
308 1.9.2.2 yamt }
309 1.9.2.2 yamt }
310 1.9.2.2 yamt
311 1.9.2.2 yamt static uint32_t
312 1.9.2.2 yamt dqblk_setlimit(uint64_t val)
313 1.9.2.2 yamt {
314 1.9.2.2 yamt if (val == QUOTA_NOLIMIT && val >= 0xffffffffUL) {
315 1.9.2.2 yamt return 0;
316 1.9.2.2 yamt } else {
317 1.9.2.2 yamt return (uint32_t)val + 1;
318 1.9.2.2 yamt }
319 1.9.2.2 yamt }
320 1.9.2.2 yamt
321 1.9.2.2 yamt static void
322 1.9.2.2 yamt dqblk_getblocks(const struct dqblk *dq, struct quotaval *qv)
323 1.9.2.2 yamt {
324 1.9.2.2 yamt qv->qv_hardlimit = dqblk_getlimit(dq->dqb_bhardlimit);
325 1.9.2.2 yamt qv->qv_softlimit = dqblk_getlimit(dq->dqb_bsoftlimit);
326 1.9.2.2 yamt qv->qv_usage = dq->dqb_curblocks;
327 1.9.2.2 yamt qv->qv_expiretime = dq->dqb_btime;
328 1.9.2.2 yamt qv->qv_grace = QUOTA_NOTIME;
329 1.9.2.2 yamt }
330 1.9.2.2 yamt
331 1.9.2.2 yamt static void
332 1.9.2.2 yamt dqblk_getfiles(const struct dqblk *dq, struct quotaval *qv)
333 1.9.2.2 yamt {
334 1.9.2.2 yamt qv->qv_hardlimit = dqblk_getlimit(dq->dqb_ihardlimit);
335 1.9.2.2 yamt qv->qv_softlimit = dqblk_getlimit(dq->dqb_isoftlimit);
336 1.9.2.2 yamt qv->qv_usage = dq->dqb_curinodes;
337 1.9.2.2 yamt qv->qv_expiretime = dq->dqb_itime;
338 1.9.2.2 yamt qv->qv_grace = QUOTA_NOTIME;
339 1.9.2.2 yamt }
340 1.9.2.2 yamt
341 1.9.2.2 yamt static void
342 1.9.2.2 yamt dqblk_putblocks(const struct quotaval *qv, struct dqblk *dq)
343 1.9.2.2 yamt {
344 1.9.2.2 yamt dq->dqb_bhardlimit = dqblk_setlimit(qv->qv_hardlimit);
345 1.9.2.2 yamt dq->dqb_bsoftlimit = dqblk_setlimit(qv->qv_softlimit);
346 1.9.2.2 yamt dq->dqb_curblocks = qv->qv_usage;
347 1.9.2.2 yamt dq->dqb_btime = qv->qv_expiretime;
348 1.9.2.2 yamt /* ignore qv->qv_grace */
349 1.9.2.2 yamt }
350 1.9.2.2 yamt
351 1.9.2.2 yamt static void
352 1.9.2.2 yamt dqblk_putfiles(const struct quotaval *qv, struct dqblk *dq)
353 1.9.2.2 yamt {
354 1.9.2.2 yamt dq->dqb_ihardlimit = dqblk_setlimit(qv->qv_hardlimit);
355 1.9.2.2 yamt dq->dqb_isoftlimit = dqblk_setlimit(qv->qv_softlimit);
356 1.9.2.2 yamt dq->dqb_curinodes = qv->qv_usage;
357 1.9.2.2 yamt dq->dqb_itime = qv->qv_expiretime;
358 1.9.2.2 yamt /* ignore qv->qv_grace */
359 1.9.2.2 yamt }
360 1.9.2.2 yamt
361 1.9.2.2 yamt static int
362 1.9.2.2 yamt __quota_oldfiles_open(struct quotahandle *qh, const char *path, int *fd_ret)
363 1.9.2.2 yamt {
364 1.9.2.2 yamt int fd;
365 1.9.2.2 yamt
366 1.9.2.2 yamt fd = open(path, O_RDWR);
367 1.9.2.2 yamt if (fd < 0 && (errno == EACCES || errno == EROFS)) {
368 1.9.2.2 yamt fd = open(path, O_RDONLY);
369 1.9.2.2 yamt if (fd < 0) {
370 1.9.2.2 yamt return -1;
371 1.9.2.2 yamt }
372 1.9.2.2 yamt }
373 1.9.2.2 yamt *fd_ret = fd;
374 1.9.2.2 yamt return 0;
375 1.9.2.2 yamt }
376 1.9.2.2 yamt
377 1.9.2.2 yamt int
378 1.9.2.2 yamt __quota_oldfiles_initialize(struct quotahandle *qh)
379 1.9.2.2 yamt {
380 1.9.2.2 yamt const struct oldfiles_fstabentry *ofe;
381 1.9.2.2 yamt char path[PATH_MAX];
382 1.9.2.2 yamt const char *userquotafile, *groupquotafile;
383 1.9.2.2 yamt
384 1.9.2.2 yamt if (qh->qh_oldfilesopen) {
385 1.9.2.2 yamt /* already initialized */
386 1.9.2.2 yamt return 0;
387 1.9.2.2 yamt }
388 1.9.2.2 yamt
389 1.9.2.2 yamt /*
390 1.9.2.2 yamt * Find the fstab entry.
391 1.9.2.2 yamt */
392 1.9.2.2 yamt ofe = __quota_oldfiles_find_fstabentry(qh->qh_mountpoint);
393 1.9.2.2 yamt if (ofe == NULL) {
394 1.9.2.2 yamt warnx("%s not found in fstab", qh->qh_mountpoint);
395 1.9.2.2 yamt errno = ENXIO;
396 1.9.2.2 yamt return -1;
397 1.9.2.2 yamt }
398 1.9.2.2 yamt
399 1.9.2.2 yamt if (!ofe->ofe_hasuserquota && !ofe->ofe_hasgroupquota) {
400 1.9.2.2 yamt errno = ENXIO;
401 1.9.2.2 yamt return -1;
402 1.9.2.2 yamt }
403 1.9.2.2 yamt
404 1.9.2.2 yamt if (ofe->ofe_hasuserquota) {
405 1.9.2.2 yamt userquotafile = ofe->ofe_userquotafile;
406 1.9.2.2 yamt if (userquotafile == NULL) {
407 1.9.2.2 yamt __quota_oldfiles_defquotafile(qh, USRQUOTA,
408 1.9.2.2 yamt path, sizeof(path));
409 1.9.2.2 yamt userquotafile = path;
410 1.9.2.2 yamt }
411 1.9.2.2 yamt if (__quota_oldfiles_open(qh, userquotafile,
412 1.9.2.2 yamt &qh->qh_userfile)) {
413 1.9.2.2 yamt return -1;
414 1.9.2.2 yamt }
415 1.9.2.2 yamt }
416 1.9.2.2 yamt if (ofe->ofe_hasgroupquota) {
417 1.9.2.2 yamt groupquotafile = ofe->ofe_groupquotafile;
418 1.9.2.2 yamt if (groupquotafile == NULL) {
419 1.9.2.2 yamt __quota_oldfiles_defquotafile(qh, GRPQUOTA,
420 1.9.2.2 yamt path, sizeof(path));
421 1.9.2.2 yamt groupquotafile = path;
422 1.9.2.2 yamt }
423 1.9.2.2 yamt if (__quota_oldfiles_open(qh, groupquotafile,
424 1.9.2.2 yamt &qh->qh_groupfile)) {
425 1.9.2.2 yamt return -1;
426 1.9.2.2 yamt }
427 1.9.2.2 yamt }
428 1.9.2.2 yamt
429 1.9.2.2 yamt qh->qh_oldfilesopen = 1;
430 1.9.2.2 yamt
431 1.9.2.2 yamt return 0;
432 1.9.2.2 yamt }
433 1.9.2.2 yamt
434 1.9.2.2 yamt const char *
435 1.9.2.2 yamt __quota_oldfiles_getimplname(struct quotahandle *qh)
436 1.9.2.2 yamt {
437 1.9.2.2 yamt return "ufs/ffs quota v1 file access";
438 1.9.2.2 yamt }
439 1.9.2.2 yamt
440 1.9.2.2 yamt int
441 1.9.2.2 yamt __quota_oldfiles_quotaon(struct quotahandle *qh, int idtype)
442 1.9.2.2 yamt {
443 1.9.2.2 yamt int result;
444 1.9.2.2 yamt
445 1.9.2.2 yamt /*
446 1.9.2.2 yamt * If we have the quota files open, close them.
447 1.9.2.2 yamt */
448 1.9.2.2 yamt
449 1.9.2.2 yamt if (qh->qh_oldfilesopen) {
450 1.9.2.2 yamt if (qh->qh_userfile >= 0) {
451 1.9.2.2 yamt close(qh->qh_userfile);
452 1.9.2.2 yamt qh->qh_userfile = -1;
453 1.9.2.2 yamt }
454 1.9.2.2 yamt if (qh->qh_groupfile >= 0) {
455 1.9.2.2 yamt close(qh->qh_groupfile);
456 1.9.2.2 yamt qh->qh_groupfile = -1;
457 1.9.2.2 yamt }
458 1.9.2.2 yamt qh->qh_oldfilesopen = 0;
459 1.9.2.2 yamt }
460 1.9.2.2 yamt
461 1.9.2.2 yamt /*
462 1.9.2.2 yamt * Go over to the syscall interface.
463 1.9.2.2 yamt */
464 1.9.2.2 yamt
465 1.9.2.2 yamt result = __quota_kernel_quotaon(qh, idtype);
466 1.9.2.2 yamt if (result < 0) {
467 1.9.2.2 yamt return -1;
468 1.9.2.2 yamt }
469 1.9.2.2 yamt
470 1.9.2.2 yamt /*
471 1.9.2.2 yamt * We succeeded, so all further access should be via the
472 1.9.2.2 yamt * kernel.
473 1.9.2.2 yamt */
474 1.9.2.2 yamt
475 1.9.2.2 yamt qh->qh_mode = QUOTA_MODE_KERNEL;
476 1.9.2.2 yamt return 0;
477 1.9.2.2 yamt }
478 1.9.2.2 yamt
479 1.9.2.2 yamt static int
480 1.9.2.2 yamt __quota_oldfiles_doget(struct quotahandle *qh, const struct quotakey *qk,
481 1.9.2.2 yamt struct quotaval *qv, int *isallzero)
482 1.9.2.2 yamt {
483 1.9.2.2 yamt int file;
484 1.9.2.2 yamt off_t pos;
485 1.9.2.2 yamt struct dqblk dq;
486 1.9.2.2 yamt ssize_t result;
487 1.9.2.2 yamt
488 1.9.2.2 yamt if (!qh->qh_oldfilesopen) {
489 1.9.2.2 yamt if (__quota_oldfiles_initialize(qh)) {
490 1.9.2.2 yamt return -1;
491 1.9.2.2 yamt }
492 1.9.2.2 yamt }
493 1.9.2.2 yamt
494 1.9.2.2 yamt switch (qk->qk_idtype) {
495 1.9.2.2 yamt case QUOTA_IDTYPE_USER:
496 1.9.2.2 yamt file = qh->qh_userfile;
497 1.9.2.2 yamt break;
498 1.9.2.2 yamt case QUOTA_IDTYPE_GROUP:
499 1.9.2.2 yamt file = qh->qh_groupfile;
500 1.9.2.2 yamt break;
501 1.9.2.2 yamt default:
502 1.9.2.2 yamt errno = EINVAL;
503 1.9.2.2 yamt return -1;
504 1.9.2.2 yamt }
505 1.9.2.2 yamt
506 1.9.2.2 yamt if (qk->qk_id == QUOTA_DEFAULTID) {
507 1.9.2.2 yamt pos = 0;
508 1.9.2.2 yamt } else {
509 1.9.2.2 yamt pos = qk->qk_id * sizeof(struct dqblk);
510 1.9.2.2 yamt }
511 1.9.2.2 yamt
512 1.9.2.2 yamt result = pread(file, &dq, sizeof(dq), pos);
513 1.9.2.2 yamt if (result < 0) {
514 1.9.2.2 yamt return -1;
515 1.9.2.2 yamt } else if (result == 0) {
516 1.9.2.2 yamt /* Past EOF; no quota info on file for this ID */
517 1.9.2.2 yamt errno = ENOENT;
518 1.9.2.2 yamt return -1;
519 1.9.2.2 yamt } else if ((size_t)result != sizeof(dq)) {
520 1.9.2.2 yamt errno = EFTYPE;
521 1.9.2.2 yamt return -1;
522 1.9.2.2 yamt }
523 1.9.2.2 yamt
524 1.9.2.2 yamt switch (qk->qk_objtype) {
525 1.9.2.2 yamt case QUOTA_OBJTYPE_BLOCKS:
526 1.9.2.2 yamt dqblk_getblocks(&dq, qv);
527 1.9.2.2 yamt break;
528 1.9.2.2 yamt case QUOTA_OBJTYPE_FILES:
529 1.9.2.2 yamt dqblk_getfiles(&dq, qv);
530 1.9.2.2 yamt break;
531 1.9.2.2 yamt default:
532 1.9.2.2 yamt errno = EINVAL;
533 1.9.2.2 yamt return -1;
534 1.9.2.2 yamt }
535 1.9.2.2 yamt
536 1.9.2.2 yamt if (qk->qk_id == QUOTA_DEFAULTID) {
537 1.9.2.2 yamt qv->qv_usage = 0;
538 1.9.2.2 yamt qv->qv_grace = qv->qv_expiretime;
539 1.9.2.2 yamt qv->qv_expiretime = QUOTA_NOTIME;
540 1.9.2.2 yamt } else if (qk->qk_id == 0) {
541 1.9.2.2 yamt qv->qv_hardlimit = 0;
542 1.9.2.2 yamt qv->qv_softlimit = 0;
543 1.9.2.2 yamt qv->qv_expiretime = QUOTA_NOTIME;
544 1.9.2.2 yamt qv->qv_grace = QUOTA_NOTIME;
545 1.9.2.2 yamt }
546 1.9.2.2 yamt
547 1.9.2.2 yamt if (isallzero != NULL) {
548 1.9.2.2 yamt if (dq.dqb_bhardlimit == 0 &&
549 1.9.2.2 yamt dq.dqb_bsoftlimit == 0 &&
550 1.9.2.2 yamt dq.dqb_curblocks == 0 &&
551 1.9.2.2 yamt dq.dqb_ihardlimit == 0 &&
552 1.9.2.2 yamt dq.dqb_isoftlimit == 0 &&
553 1.9.2.2 yamt dq.dqb_curinodes == 0 &&
554 1.9.2.2 yamt dq.dqb_btime == 0 &&
555 1.9.2.2 yamt dq.dqb_itime == 0) {
556 1.9.2.2 yamt *isallzero = 1;
557 1.9.2.2 yamt } else {
558 1.9.2.2 yamt *isallzero = 0;
559 1.9.2.2 yamt }
560 1.9.2.2 yamt }
561 1.9.2.2 yamt
562 1.9.2.2 yamt return 0;
563 1.9.2.2 yamt }
564 1.9.2.2 yamt
565 1.9.2.2 yamt static int
566 1.9.2.2 yamt __quota_oldfiles_doput(struct quotahandle *qh, const struct quotakey *qk,
567 1.9.2.2 yamt const struct quotaval *qv)
568 1.9.2.2 yamt {
569 1.9.2.2 yamt int file;
570 1.9.2.2 yamt off_t pos;
571 1.9.2.2 yamt struct quotaval qv2;
572 1.9.2.2 yamt struct dqblk dq;
573 1.9.2.2 yamt ssize_t result;
574 1.9.2.2 yamt
575 1.9.2.2 yamt if (!qh->qh_oldfilesopen) {
576 1.9.2.2 yamt if (__quota_oldfiles_initialize(qh)) {
577 1.9.2.2 yamt return -1;
578 1.9.2.2 yamt }
579 1.9.2.2 yamt }
580 1.9.2.2 yamt
581 1.9.2.2 yamt switch (qk->qk_idtype) {
582 1.9.2.2 yamt case QUOTA_IDTYPE_USER:
583 1.9.2.2 yamt file = qh->qh_userfile;
584 1.9.2.2 yamt break;
585 1.9.2.2 yamt case QUOTA_IDTYPE_GROUP:
586 1.9.2.2 yamt file = qh->qh_groupfile;
587 1.9.2.2 yamt break;
588 1.9.2.2 yamt default:
589 1.9.2.2 yamt errno = EINVAL;
590 1.9.2.2 yamt return -1;
591 1.9.2.2 yamt }
592 1.9.2.2 yamt
593 1.9.2.2 yamt if (qk->qk_id == QUOTA_DEFAULTID) {
594 1.9.2.2 yamt pos = 0;
595 1.9.2.2 yamt } else {
596 1.9.2.2 yamt pos = qk->qk_id * sizeof(struct dqblk);
597 1.9.2.2 yamt }
598 1.9.2.2 yamt
599 1.9.2.2 yamt result = pread(file, &dq, sizeof(dq), pos);
600 1.9.2.2 yamt if (result < 0) {
601 1.9.2.2 yamt return -1;
602 1.9.2.2 yamt } else if (result == 0) {
603 1.9.2.2 yamt /* Past EOF; fill in a blank dq to start from */
604 1.9.2.2 yamt dq.dqb_bhardlimit = 0;
605 1.9.2.2 yamt dq.dqb_bsoftlimit = 0;
606 1.9.2.2 yamt dq.dqb_curblocks = 0;
607 1.9.2.2 yamt dq.dqb_ihardlimit = 0;
608 1.9.2.2 yamt dq.dqb_isoftlimit = 0;
609 1.9.2.2 yamt dq.dqb_curinodes = 0;
610 1.9.2.2 yamt dq.dqb_btime = 0;
611 1.9.2.2 yamt dq.dqb_itime = 0;
612 1.9.2.2 yamt } else if ((size_t)result != sizeof(dq)) {
613 1.9.2.2 yamt errno = EFTYPE;
614 1.9.2.2 yamt return -1;
615 1.9.2.2 yamt }
616 1.9.2.2 yamt
617 1.9.2.2 yamt switch (qk->qk_objtype) {
618 1.9.2.2 yamt case QUOTA_OBJTYPE_BLOCKS:
619 1.9.2.2 yamt dqblk_getblocks(&dq, &qv2);
620 1.9.2.2 yamt break;
621 1.9.2.2 yamt case QUOTA_OBJTYPE_FILES:
622 1.9.2.2 yamt dqblk_getfiles(&dq, &qv2);
623 1.9.2.2 yamt break;
624 1.9.2.2 yamt default:
625 1.9.2.2 yamt errno = EINVAL;
626 1.9.2.2 yamt return -1;
627 1.9.2.2 yamt }
628 1.9.2.2 yamt
629 1.9.2.2 yamt if (qk->qk_id == QUOTA_DEFAULTID) {
630 1.9.2.2 yamt qv2.qv_hardlimit = qv->qv_hardlimit;
631 1.9.2.2 yamt qv2.qv_softlimit = qv->qv_softlimit;
632 1.9.2.2 yamt /* leave qv2.qv_usage unchanged */
633 1.9.2.2 yamt qv2.qv_expiretime = qv->qv_grace;
634 1.9.2.2 yamt /* skip qv2.qv_grace */
635 1.9.2.2 yamt
636 1.9.2.2 yamt /* ignore qv->qv_usage */
637 1.9.2.2 yamt /* ignore qv->qv_expiretime */
638 1.9.2.2 yamt } else if (qk->qk_id == 0) {
639 1.9.2.2 yamt /* leave qv2.qv_hardlimit unchanged */
640 1.9.2.2 yamt /* leave qv2.qv_softlimit unchanged */
641 1.9.2.2 yamt qv2.qv_usage = qv->qv_usage;
642 1.9.2.2 yamt /* leave qv2.qv_expiretime unchanged */
643 1.9.2.2 yamt /* skip qv2.qv_grace */
644 1.9.2.2 yamt
645 1.9.2.2 yamt /* ignore qv->qv_hardlimit */
646 1.9.2.2 yamt /* ignore qv->qv_softlimit */
647 1.9.2.2 yamt /* ignore qv->qv_expiretime */
648 1.9.2.2 yamt /* ignore qv->qv_grace */
649 1.9.2.2 yamt } else {
650 1.9.2.2 yamt qv2 = *qv;
651 1.9.2.2 yamt }
652 1.9.2.2 yamt
653 1.9.2.2 yamt switch (qk->qk_objtype) {
654 1.9.2.2 yamt case QUOTA_OBJTYPE_BLOCKS:
655 1.9.2.2 yamt dqblk_putblocks(&qv2, &dq);
656 1.9.2.2 yamt break;
657 1.9.2.2 yamt case QUOTA_OBJTYPE_FILES:
658 1.9.2.2 yamt dqblk_putfiles(&qv2, &dq);
659 1.9.2.2 yamt break;
660 1.9.2.2 yamt default:
661 1.9.2.2 yamt errno = EINVAL;
662 1.9.2.2 yamt return -1;
663 1.9.2.2 yamt }
664 1.9.2.2 yamt
665 1.9.2.2 yamt result = pwrite(file, &dq, sizeof(dq), pos);
666 1.9.2.2 yamt if (result < 0) {
667 1.9.2.2 yamt return -1;
668 1.9.2.2 yamt } else if ((size_t)result != sizeof(dq)) {
669 1.9.2.2 yamt /* ? */
670 1.9.2.2 yamt errno = EFTYPE;
671 1.9.2.2 yamt return -1;
672 1.9.2.2 yamt }
673 1.9.2.2 yamt
674 1.9.2.2 yamt return 0;
675 1.9.2.2 yamt }
676 1.9.2.2 yamt
677 1.9.2.2 yamt int
678 1.9.2.2 yamt __quota_oldfiles_get(struct quotahandle *qh, const struct quotakey *qk,
679 1.9.2.2 yamt struct quotaval *qv)
680 1.9.2.2 yamt {
681 1.9.2.2 yamt return __quota_oldfiles_doget(qh, qk, qv, NULL);
682 1.9.2.2 yamt }
683 1.9.2.2 yamt
684 1.9.2.2 yamt int
685 1.9.2.2 yamt __quota_oldfiles_put(struct quotahandle *qh, const struct quotakey *qk,
686 1.9.2.2 yamt const struct quotaval *qv)
687 1.9.2.2 yamt {
688 1.9.2.2 yamt return __quota_oldfiles_doput(qh, qk, qv);
689 1.9.2.2 yamt }
690 1.9.2.2 yamt
691 1.9.2.2 yamt int
692 1.9.2.2 yamt __quota_oldfiles_delete(struct quotahandle *qh, const struct quotakey *qk)
693 1.9.2.2 yamt {
694 1.9.2.2 yamt struct quotaval qv;
695 1.9.2.2 yamt
696 1.9.2.2 yamt quotaval_clear(&qv);
697 1.9.2.2 yamt return __quota_oldfiles_doput(qh, qk, &qv);
698 1.9.2.2 yamt }
699 1.9.2.2 yamt
700 1.9.2.2 yamt struct oldfiles_quotacursor *
701 1.9.2.2 yamt __quota_oldfiles_cursor_create(struct quotahandle *qh)
702 1.9.2.2 yamt {
703 1.9.2.2 yamt struct oldfiles_quotacursor *oqc;
704 1.9.2.2 yamt struct stat st;
705 1.9.2.2 yamt int serrno;
706 1.9.2.2 yamt
707 1.9.2.2 yamt /* quota_opencursor calls initialize for us, no need to do it here */
708 1.9.2.2 yamt
709 1.9.2.2 yamt oqc = malloc(sizeof(*oqc));
710 1.9.2.2 yamt if (oqc == NULL) {
711 1.9.2.2 yamt return NULL;
712 1.9.2.2 yamt }
713 1.9.2.2 yamt
714 1.9.2.2 yamt oqc->oqc_didusers = 0;
715 1.9.2.2 yamt oqc->oqc_didgroups = 0;
716 1.9.2.2 yamt oqc->oqc_diddefault = 0;
717 1.9.2.2 yamt oqc->oqc_pos = 0;
718 1.9.2.2 yamt oqc->oqc_didblocks = 0;
719 1.9.2.2 yamt
720 1.9.2.2 yamt if (qh->qh_userfile >= 0) {
721 1.9.2.2 yamt oqc->oqc_doingusers = 1;
722 1.9.2.2 yamt } else {
723 1.9.2.2 yamt oqc->oqc_doingusers = 0;
724 1.9.2.2 yamt oqc->oqc_didusers = 1;
725 1.9.2.2 yamt }
726 1.9.2.2 yamt
727 1.9.2.2 yamt if (qh->qh_groupfile >= 0) {
728 1.9.2.2 yamt oqc->oqc_doinggroups = 1;
729 1.9.2.2 yamt } else {
730 1.9.2.2 yamt oqc->oqc_doinggroups = 0;
731 1.9.2.2 yamt oqc->oqc_didgroups = 1;
732 1.9.2.2 yamt }
733 1.9.2.2 yamt
734 1.9.2.2 yamt if (fstat(qh->qh_userfile, &st) < 0) {
735 1.9.2.2 yamt serrno = errno;
736 1.9.2.2 yamt free(oqc);
737 1.9.2.2 yamt errno = serrno;
738 1.9.2.2 yamt return NULL;
739 1.9.2.2 yamt }
740 1.9.2.2 yamt oqc->oqc_numusers = st.st_size / sizeof(struct dqblk);
741 1.9.2.2 yamt
742 1.9.2.2 yamt if (fstat(qh->qh_groupfile, &st) < 0) {
743 1.9.2.2 yamt serrno = errno;
744 1.9.2.2 yamt free(oqc);
745 1.9.2.2 yamt errno = serrno;
746 1.9.2.2 yamt return NULL;
747 1.9.2.2 yamt }
748 1.9.2.2 yamt oqc->oqc_numgroups = st.st_size / sizeof(struct dqblk);
749 1.9.2.2 yamt
750 1.9.2.2 yamt return oqc;
751 1.9.2.2 yamt }
752 1.9.2.2 yamt
753 1.9.2.2 yamt void
754 1.9.2.2 yamt __quota_oldfiles_cursor_destroy(struct oldfiles_quotacursor *oqc)
755 1.9.2.2 yamt {
756 1.9.2.2 yamt free(oqc);
757 1.9.2.2 yamt }
758 1.9.2.2 yamt
759 1.9.2.2 yamt int
760 1.9.2.2 yamt __quota_oldfiles_cursor_skipidtype(struct oldfiles_quotacursor *oqc,
761 1.9.2.2 yamt int idtype)
762 1.9.2.2 yamt {
763 1.9.2.2 yamt switch (idtype) {
764 1.9.2.2 yamt case QUOTA_IDTYPE_USER:
765 1.9.2.2 yamt oqc->oqc_doingusers = 0;
766 1.9.2.2 yamt oqc->oqc_didusers = 1;
767 1.9.2.2 yamt break;
768 1.9.2.2 yamt case QUOTA_IDTYPE_GROUP:
769 1.9.2.2 yamt oqc->oqc_doinggroups = 0;
770 1.9.2.2 yamt oqc->oqc_didgroups = 1;
771 1.9.2.2 yamt break;
772 1.9.2.2 yamt default:
773 1.9.2.2 yamt errno = EINVAL;
774 1.9.2.2 yamt return -1;
775 1.9.2.2 yamt }
776 1.9.2.2 yamt return 0;
777 1.9.2.2 yamt }
778 1.9.2.2 yamt
779 1.9.2.2 yamt int
780 1.9.2.2 yamt __quota_oldfiles_cursor_get(struct quotahandle *qh,
781 1.9.2.2 yamt struct oldfiles_quotacursor *oqc,
782 1.9.2.2 yamt struct quotakey *key, struct quotaval *val)
783 1.9.2.2 yamt {
784 1.9.2.2 yamt unsigned maxpos;
785 1.9.2.2 yamt int isallzero;
786 1.9.2.2 yamt
787 1.9.2.2 yamt /* in case one of the sizes is zero */
788 1.9.2.2 yamt if (!oqc->oqc_didusers && oqc->oqc_pos >= oqc->oqc_numusers) {
789 1.9.2.2 yamt oqc->oqc_didusers = 1;
790 1.9.2.2 yamt }
791 1.9.2.2 yamt if (!oqc->oqc_didgroups && oqc->oqc_pos >= oqc->oqc_numgroups) {
792 1.9.2.2 yamt oqc->oqc_didgroups = 1;
793 1.9.2.2 yamt }
794 1.9.2.2 yamt
795 1.9.2.2 yamt again:
796 1.9.2.2 yamt /*
797 1.9.2.2 yamt * Figure out what to get
798 1.9.2.2 yamt */
799 1.9.2.2 yamt
800 1.9.2.2 yamt if (!oqc->oqc_didusers) {
801 1.9.2.2 yamt key->qk_idtype = QUOTA_IDTYPE_USER;
802 1.9.2.2 yamt maxpos = oqc->oqc_numusers;
803 1.9.2.2 yamt } else if (!oqc->oqc_didgroups) {
804 1.9.2.2 yamt key->qk_idtype = QUOTA_IDTYPE_GROUP;
805 1.9.2.2 yamt maxpos = oqc->oqc_numgroups;
806 1.9.2.2 yamt } else {
807 1.9.2.2 yamt errno = ENOENT;
808 1.9.2.2 yamt return -1;
809 1.9.2.2 yamt }
810 1.9.2.2 yamt
811 1.9.2.2 yamt if (!oqc->oqc_diddefault) {
812 1.9.2.2 yamt key->qk_id = QUOTA_DEFAULTID;
813 1.9.2.2 yamt } else {
814 1.9.2.2 yamt key->qk_id = oqc->oqc_pos;
815 1.9.2.2 yamt }
816 1.9.2.2 yamt
817 1.9.2.2 yamt if (!oqc->oqc_didblocks) {
818 1.9.2.2 yamt key->qk_objtype = QUOTA_OBJTYPE_BLOCKS;
819 1.9.2.2 yamt } else {
820 1.9.2.2 yamt key->qk_objtype = QUOTA_OBJTYPE_FILES;
821 1.9.2.2 yamt }
822 1.9.2.2 yamt
823 1.9.2.2 yamt /*
824 1.9.2.2 yamt * Get it
825 1.9.2.2 yamt */
826 1.9.2.2 yamt
827 1.9.2.2 yamt if (__quota_oldfiles_doget(qh, key, val, &isallzero)) {
828 1.9.2.2 yamt return -1;
829 1.9.2.2 yamt }
830 1.9.2.2 yamt
831 1.9.2.2 yamt /*
832 1.9.2.2 yamt * Advance the cursor
833 1.9.2.2 yamt */
834 1.9.2.2 yamt if (!oqc->oqc_didblocks) {
835 1.9.2.2 yamt oqc->oqc_didblocks = 1;
836 1.9.2.2 yamt } else {
837 1.9.2.2 yamt oqc->oqc_didblocks = 0;
838 1.9.2.2 yamt if (!oqc->oqc_diddefault) {
839 1.9.2.2 yamt oqc->oqc_diddefault = 1;
840 1.9.2.2 yamt } else {
841 1.9.2.2 yamt oqc->oqc_pos++;
842 1.9.2.2 yamt if (oqc->oqc_pos >= maxpos) {
843 1.9.2.2 yamt oqc->oqc_pos = 0;
844 1.9.2.2 yamt oqc->oqc_diddefault = 0;
845 1.9.2.2 yamt if (!oqc->oqc_didusers) {
846 1.9.2.2 yamt oqc->oqc_didusers = 1;
847 1.9.2.2 yamt } else {
848 1.9.2.2 yamt oqc->oqc_didgroups = 1;
849 1.9.2.2 yamt }
850 1.9.2.2 yamt }
851 1.9.2.2 yamt }
852 1.9.2.2 yamt }
853 1.9.2.2 yamt
854 1.9.2.2 yamt /*
855 1.9.2.2 yamt * If we got an all-zero dqblk (e.g. from the middle of a hole
856 1.9.2.2 yamt * in the quota file) don't bother returning it to the caller.
857 1.9.2.2 yamt *
858 1.9.2.2 yamt * ...unless we're at the end of the data, to avoid going past
859 1.9.2.2 yamt * the end and generating a spurious failure. There's no
860 1.9.2.2 yamt * reasonable way to make _atend detect empty entries at the
861 1.9.2.2 yamt * end of the quota files.
862 1.9.2.2 yamt */
863 1.9.2.2 yamt if (isallzero && (!oqc->oqc_didusers || !oqc->oqc_didgroups)) {
864 1.9.2.2 yamt goto again;
865 1.9.2.2 yamt }
866 1.9.2.2 yamt return 0;
867 1.9.2.2 yamt }
868 1.9.2.2 yamt
869 1.9.2.2 yamt int
870 1.9.2.2 yamt __quota_oldfiles_cursor_getn(struct quotahandle *qh,
871 1.9.2.2 yamt struct oldfiles_quotacursor *oqc,
872 1.9.2.2 yamt struct quotakey *keys, struct quotaval *vals,
873 1.9.2.2 yamt unsigned maxnum)
874 1.9.2.2 yamt {
875 1.9.2.2 yamt unsigned i;
876 1.9.2.2 yamt
877 1.9.2.2 yamt if (maxnum > INT_MAX) {
878 1.9.2.2 yamt /* joker, eh? */
879 1.9.2.2 yamt errno = EINVAL;
880 1.9.2.2 yamt return -1;
881 1.9.2.2 yamt }
882 1.9.2.2 yamt
883 1.9.2.2 yamt for (i=0; i<maxnum; i++) {
884 1.9.2.2 yamt if (__quota_oldfiles_cursor_atend(oqc)) {
885 1.9.2.2 yamt break;
886 1.9.2.2 yamt }
887 1.9.2.2 yamt if (__quota_oldfiles_cursor_get(qh, oqc, &keys[i], &vals[i])) {
888 1.9.2.2 yamt if (i > 0) {
889 1.9.2.2 yamt /*
890 1.9.2.2 yamt * Succeed witih what we have so far;
891 1.9.2.2 yamt * the next attempt will hit the same
892 1.9.2.2 yamt * error again.
893 1.9.2.2 yamt */
894 1.9.2.2 yamt break;
895 1.9.2.2 yamt }
896 1.9.2.2 yamt return -1;
897 1.9.2.2 yamt }
898 1.9.2.2 yamt }
899 1.9.2.2 yamt return i;
900 1.9.2.2 yamt
901 1.9.2.2 yamt }
902 1.9.2.2 yamt
903 1.9.2.2 yamt int
904 1.9.2.2 yamt __quota_oldfiles_cursor_atend(struct oldfiles_quotacursor *oqc)
905 1.9.2.2 yamt {
906 1.9.2.2 yamt /* in case one of the sizes is zero */
907 1.9.2.2 yamt if (!oqc->oqc_didusers && oqc->oqc_pos >= oqc->oqc_numusers) {
908 1.9.2.2 yamt oqc->oqc_didusers = 1;
909 1.9.2.2 yamt }
910 1.9.2.2 yamt if (!oqc->oqc_didgroups && oqc->oqc_pos >= oqc->oqc_numgroups) {
911 1.9.2.2 yamt oqc->oqc_didgroups = 1;
912 1.9.2.2 yamt }
913 1.9.2.2 yamt
914 1.9.2.2 yamt return oqc->oqc_didusers && oqc->oqc_didgroups;
915 1.9.2.2 yamt }
916 1.9.2.2 yamt
917 1.9.2.2 yamt int
918 1.9.2.2 yamt __quota_oldfiles_cursor_rewind(struct oldfiles_quotacursor *oqc)
919 1.9.2.2 yamt {
920 1.9.2.2 yamt oqc->oqc_didusers = 0;
921 1.9.2.2 yamt oqc->oqc_didgroups = 0;
922 1.9.2.2 yamt oqc->oqc_diddefault = 0;
923 1.9.2.2 yamt oqc->oqc_pos = 0;
924 1.9.2.2 yamt oqc->oqc_didblocks = 0;
925 1.9.2.2 yamt return 0;
926 1.9.2.2 yamt }
927