738fcc155e50004182acee0bd44e1bae1898373a
[openafs.git] / src / vol / partition.c
1 /*
2  * Copyright 2000, International Business Machines Corporation and others.
3  * All Rights Reserved.
4  *
5  * This software has been released under the terms of the IBM Public
6  * License.  For details, see the LICENSE file in the top-level source
7  * directory or online at http://www.openafs.org/dl/license10.html
8  *
9  * Portions Copyright (c) 2003 Apple Computer, Inc.
10  * Portions Copyright (c) 2006 Sine Nomine Associates
11  */
12
13 /*
14
15         System:         VICE-TWO
16         Module:         partition.c
17         Institution:    The Information Technology Center, Carnegie-Mellon University
18
19  */
20
21 #include <afsconfig.h>
22 #include <afs/param.h>
23
24 #include <roken.h>
25
26 #include <ctype.h>
27
28 #ifdef AFS_NT40_ENV
29 #include <windows.h>
30 #include <winbase.h>
31 #include <winioctl.h>
32 #else
33
34 #if AFS_HAVE_STATVFS || AFS_HAVE_STATVFS64
35 #include <sys/statvfs.h>
36 #endif /* AFS_HAVE_STATVFS */
37 #if defined(AFS_DARWIN_ENV) || defined(AFS_XBSD_ENV)
38 #include <sys/mount.h>
39 #endif
40
41 #if !defined(AFS_SGI_ENV)
42 #ifdef  AFS_OSF_ENV
43 #include <sys/mount.h>
44 #include <ufs/fs.h>
45 #else /* AFS_OSF_ENV */
46 #ifdef AFS_VFSINCL_ENV
47 #define VFS
48 #ifdef  AFS_SUN5_ENV
49 #include <sys/fs/ufs_fs.h>
50 #else
51 #if defined(AFS_DARWIN_ENV) || defined(AFS_XBSD_ENV)
52 #include <ufs/ufs/dinode.h>
53 #include <ufs/ffs/fs.h>
54 #else
55 #include <ufs/fs.h>
56 #endif
57 #endif
58 #else /* AFS_VFSINCL_ENV */
59 #if !defined(AFS_AIX_ENV) && !defined(AFS_LINUX22_ENV) && !defined(AFS_DARWIN_ENV) && !defined(AFS_XBSD_ENV)
60 #include <sys/fs.h>
61 #endif
62 #endif /* AFS_VFSINCL_ENV */
63 #endif /* AFS_OSF_ENV */
64 #include <sys/file.h>
65 #ifdef  AFS_AIX_ENV
66 #include <sys/vfs.h>
67 #include <sys/lockf.h>
68 #else
69 #ifdef  AFS_HPUX_ENV
70 #include <sys/vfs.h>
71 #include <checklist.h>
72 #else
73 #if     defined(AFS_SUN_ENV)
74 #include <sys/vfs.h>
75 #ifndef AFS_SUN5_ENV
76 #include <mntent.h>
77 #endif
78 #endif
79 #ifdef AFS_SUN5_ENV
80 #include <sys/mnttab.h>
81 #include <sys/mntent.h>
82 #else
83 #ifdef AFS_LINUX22_ENV
84 #include <mntent.h>
85 #include <sys/statfs.h>
86 #else
87 #include <fstab.h>
88 #endif
89 #endif
90 #endif
91 #endif
92 #endif /* AFS_SGI_ENV */
93 #endif /* AFS_NT40_ENV */
94 #if defined(AFS_SGI_ENV)
95 #include <sys/file.h>
96 #include <mntent.h>
97 #endif
98
99 #include <rx/xdr.h>
100 #include <afs/afsint.h>
101 #include "nfs.h"
102 #include <afs/errors.h>
103 #include "lock.h"
104 #include "lwp.h"
105 #include <afs/afssyscalls.h>
106 #include "ihandle.h"
107 #include "common.h"
108 #ifdef AFS_NAMEI_ENV
109 #ifdef AFS_NT40_ENV
110 #include "ntops.h"
111 #else
112 #include "namei_ops.h"
113 #endif /* AFS_NT40_ENV */
114 #endif /* AFS_NAMEI_ENV */
115 #include "vnode.h"
116 #include "volume.h"
117 #include "partition.h"
118
119 #if defined(AFS_HPUX_ENV)
120 #include <sys/privgrp.h>
121 #endif /* defined(AFS_HPUX_ENV) */
122
123 #ifdef AFS_AIX42_ENV
124 #include <jfs/filsys.h>
125 #endif
126
127 #ifdef AFS_NT40_ENV
128 extern int VValidVPTEntry(struct vptab *vptp);
129 #endif
130
131 int aixlow_water = 8;           /* default 8% */
132 struct DiskPartition64 *DiskPartitionList;
133
134 #ifdef AFS_DEMAND_ATTACH_FS
135 /* file to lock to conceptually "lock" the vol headers on a partition */
136 #define AFS_PARTLOCK_FILE ".volheaders.lock"
137 #define AFS_VOLUMELOCK_FILE ".volume.lock"
138
139 static struct DiskPartition64 *DiskPartitionTable[VOLMAXPARTS+1];
140
141 static struct DiskPartition64 * VLookupPartition_r(char * path);
142 static void AddPartitionToTable_r(struct DiskPartition64 *);
143 #endif /* AFS_DEMAND_ATTACH_FS */
144
145 #ifdef AFS_SGI_XFS_IOPS_ENV
146 /* Verify that the on disk XFS inodes on the partition are large enough to
147  * hold the AFS attribute. Returns -1 if the attribute can't be set or is
148  * too small to fit in the inode. Returns 0 if the attribute does fit in
149  * the XFS inode.
150  */
151 #include <afs/xfsattrs.h>
152 static int
153 VerifyXFSInodeSize(char *part, char *fstype)
154 {
155     afs_xfs_attr_t junk;
156     int length = SIZEOF_XFS_ATTR_T;
157     int fd = 0;
158     int code = -1;
159     struct fsxattr fsx;
160
161     if (strcmp("xfs", fstype))
162         return 0;
163
164     if (attr_set(part, AFS_XFS_ATTR, &junk, length, ATTR_ROOT) == 0) {
165         if (((fd = open(part, O_RDONLY, 0)) != -1)
166             && (fcntl(fd, F_FSGETXATTRA, &fsx) == 0)) {
167
168             if (fsx.fsx_nextents) {
169                 Log("Partition %s: XFS inodes too small, exiting.\n", part);
170                 Log("Run xfs_size_check utility and remake partitions.\n");
171             } else
172                 code = 0;
173         }
174
175         if (fd > 0)
176             close(fd);
177         (void)attr_remove(part, AFS_XFS_ATTR, ATTR_ROOT);
178     }
179     return code;
180 }
181 #endif /* AFS_SGI_XFS_IOPS_ENV */
182
183 int
184 VInitPartitionPackage(void)
185 {
186 #ifdef AFS_DEMAND_ATTACH_FS
187     memset(&DiskPartitionTable, 0, sizeof(DiskPartitionTable));
188 #endif /* AFS_DEMAND_ATTACH_FS */
189     return 0;
190 }
191
192 static void
193 VInitPartition_r(char *path, char *devname, Device dev)
194 {
195     struct DiskPartition64 *dp, *op;
196
197     dp = malloc(sizeof(struct DiskPartition64));
198     /* Add it to the end, to preserve order when we print statistics */
199     for (op = DiskPartitionList; op; op = op->next) {
200         if (!op->next)
201             break;
202     }
203     if (op)
204         op->next = dp;
205     else
206         DiskPartitionList = dp;
207     dp->next = 0;
208     dp->name = strdup(path);
209     dp->index = volutil_GetPartitionID(path);
210 #if defined(AFS_NAMEI_ENV) && !defined(AFS_NT40_ENV)
211     /* Create a lockfile for the partition, of the form /vicepa/Lock/vicepa */
212     dp->devName = malloc(2 * strlen(path) + 6);
213     strcpy(dp->devName, path);
214     strcat(dp->devName, OS_DIRSEP);
215     strcat(dp->devName, "Lock");
216     mkdir(dp->devName, 0700);
217     strcat(dp->devName, path);
218     close(afs_open(dp->devName, O_RDWR | O_CREAT, 0600));
219     dp->device = dp->index;
220 #else
221     dp->devName = strdup(devname);
222     dp->device = dev;
223 #endif
224     dp->lock_fd = INVALID_FD;
225     dp->flags = 0;
226     dp->f_files = 1;            /* just a default value */
227 #if defined(AFS_NAMEI_ENV) && !defined(AFS_NT40_ENV)
228     if (programType == fileServer)
229         (void)namei_ViceREADME(VPartitionPath(dp));
230 #endif
231     VSetPartitionDiskUsage_r(dp);
232 #ifdef AFS_DEMAND_ATTACH_FS
233     AddPartitionToTable_r(dp);
234     queue_Init(&dp->vol_list.head);
235     CV_INIT(&dp->vol_list.cv, "vol list", CV_DEFAULT, 0);
236     dp->vol_list.len = 0;
237     dp->vol_list.busy = 0;
238     {
239         char lockpath[MAXPATHLEN+1];
240         snprintf(lockpath, MAXPATHLEN, "%s/" AFS_PARTLOCK_FILE, dp->name);
241         lockpath[MAXPATHLEN] = '\0';
242         VLockFileInit(&dp->headerLockFile, lockpath);
243
244         snprintf(lockpath, MAXPATHLEN, "%s/" AFS_VOLUMELOCK_FILE, dp->name);
245         lockpath[MAXPATHLEN] = '\0';
246         VLockFileInit(&dp->volLockFile, lockpath);
247     }
248     VDiskLockInit(&dp->headerLock, &dp->headerLockFile, 1);
249 #endif /* AFS_DEMAND_ATTACH_FS */
250 }
251
252 static void
253 VInitPartition(char *path, char *devname, Device dev)
254 {
255     VOL_LOCK;
256     VInitPartition_r(path, devname, dev);
257     VOL_UNLOCK;
258 }
259
260 #ifndef AFS_NT40_ENV
261 /* VAttachPartitions() finds the vice partitions on this server. Calls
262  * VCheckPartition() to do some basic checks on the partition. If the partition
263  * is a valid vice partition, VCheckPartition will add it to the DiskPartition
264  * list.
265  * Returns the number of errors returned by VCheckPartition. An error in
266  * VCheckPartition means that partition is a valid vice partition but the
267  * fileserver should not start because of the error found on that partition.
268  *
269  * AFS_NAMEI_ENV
270  * No specific user space file system checks, since we don't know what
271  * is being used for vice partitions.
272  *
273  * Use partition name as devname.
274  */
275 static int
276 VCheckPartition(char *part, char *devname, int logging)
277 {
278     struct afs_stat_st status;
279 #if !defined(AFS_LINUX20_ENV) && !defined(AFS_NT40_ENV)
280     char AFSIDatPath[MAXPATHLEN];
281 #endif
282
283     /* Only keep track of "/vicepx" partitions since it can get hairy
284      * when NFS mounts are involved.. */
285     if (strncmp(part, VICE_PARTITION_PREFIX, VICE_PREFIX_SIZE)) {
286         return 0;
287     }
288     if (afs_stat(part, &status) < 0) {
289         Log("VInitVnodes: Couldn't find file system %s; ignored\n", part);
290         return 0;
291     }
292     if (logging) {
293         Log("This program is compiled without AFS_NAMEI_ENV, and "
294             "partition %s is mounted with the 'logging' option. "
295             "Using the inode fileserver backend with 'logging' UFS "
296             "partitions causes volume corruption, so please either "
297             "mount the partition without logging, or use the namei "
298             "fileserver backend. Aborting...\n", part);
299         return -1;
300     }
301 #ifndef AFS_AIX32_ENV
302     if (programType == fileServer) {
303         char salvpath[MAXPATHLEN];
304         strcpy(salvpath, part);
305         strcat(salvpath, "/FORCESALVAGE");
306         if (afs_stat(salvpath, &status) == 0) {
307             Log("VInitVnodes: Found %s; aborting\n", salvpath);
308             return -1;
309         }
310     }
311 #endif
312
313 #if !defined(AFS_LINUX20_ENV) && !defined(AFS_NT40_ENV)
314     strcpy(AFSIDatPath, part);
315     strcat(AFSIDatPath, "/AFSIDat");
316 #ifdef AFS_NAMEI_ENV
317     if (afs_stat(AFSIDatPath, &status) < 0) {
318         DIR *dirp;
319         struct dirent *dp;
320
321         dirp = opendir(part);
322         osi_Assert(dirp);
323         while ((dp = readdir(dirp))) {
324             if (dp->d_name[0] == 'V') {
325                 Log("This program is compiled with AFS_NAMEI_ENV, but partition %s seems to contain volumes which don't use the namei-interface; aborting\n", part);
326                 closedir(dirp);
327                 return -1;
328             }
329         }
330         closedir(dirp);
331     }
332 #else /* AFS_NAMEI_ENV */
333     if (afs_stat(AFSIDatPath, &status) == 0) {
334         Log("This program is compiled without AFS_NAMEI_ENV, but partition %s seems to contain volumes which use the namei-interface; aborting\n", part);
335         return -1;
336     }
337
338 #ifdef AFS_SGI_XFS_IOPS_ENV
339     if (VerifyXFSInodeSize(part, status.st_fstype) < 0)
340         return -1;
341 #endif
342 #endif /* AFS_NAMEI_ENV */
343 #endif /* !AFS_LINUX20_ENV && !AFS_NT40_ENV */
344
345 #if defined(AFS_DUX40_ENV) && !defined(AFS_NAMEI_ENV)
346     if (status.st_ino != ROOTINO) {
347         Log("%s is not a mounted file system; ignored.\n", part);
348         return 0;
349     }
350 #endif
351
352     VInitPartition(part, devname, status.st_dev);
353
354     return 0;
355 }
356
357 /* VIsAlwaysAttach() checks whether a /vicepX directory should always be
358  * attached (return value 1), or only attached when it is a separately
359  * mounted partition (return value 0).  For non-NAMEI environments, it
360  * always returns 0.
361  *
362  * *awouldattach will be set to 1 if the given path at least looks like a vice
363  * partition (that is, if we return 0, the only thing preventing this partition
364  * from being attached is the existence of the AlwaysAttach file), or to 0
365  * otherwise. *awouldattach is set regardless of whether or not the partition
366  * should always be attached or not.
367  */
368 static int
369 VIsAlwaysAttach(char *part, int *awouldattach)
370 {
371 #ifdef AFS_NAMEI_ENV
372     struct afs_stat_st st;
373     char checkfile[256];
374     int ret;
375 #endif /* AFS_NAMEI_ENV */
376
377     if (awouldattach) {
378         *awouldattach = 0;
379     }
380
381 #ifdef AFS_NAMEI_ENV
382     if (strncmp(part, VICE_PARTITION_PREFIX, VICE_PREFIX_SIZE))
383         return 0;
384
385     if (awouldattach) {
386         *awouldattach = 1;
387     }
388
389     strncpy(checkfile, part, 100);
390     strcat(checkfile, OS_DIRSEP);
391     strcat(checkfile, VICE_ALWAYSATTACH_FILE);
392
393     ret = afs_stat(checkfile, &st);
394     return (ret < 0) ? 0 : 1;
395 #else /* AFS_NAMEI_ENV */
396     return 0;
397 #endif /* AFS_NAMEI_ENV */
398 }
399
400 /* VIsNeverAttach() checks whether a /vicepX directory should never be
401  * attached (return value 1), or follow the normal mounting logic. The
402  * Always Attach flag may override the NeverAttach flag.
403  */
404 static int
405 VIsNeverAttach(char *part)
406 {
407     struct afs_stat_st st;
408     char checkfile[256];
409     int ret;
410
411     if (strncmp(part, VICE_PARTITION_PREFIX, VICE_PREFIX_SIZE))
412         return 0;
413
414     strncpy(checkfile, part, 100);
415     strcat(checkfile, OS_DIRSEP);
416     strcat(checkfile, VICE_NEVERATTACH_FILE);
417
418     ret = afs_stat(checkfile, &st);
419     return (ret < 0) ? 0 : 1;
420 }
421
422 /* VAttachPartitions2() looks for and attaches /vicepX partitions
423  * where a special file (VICE_ALWAYSATTACH_FILE) exists.  This is
424  * used to attach /vicepX directories which aren't on dedicated
425  * partitions, in the NAMEI fileserver.
426  */
427 static void
428 VAttachPartitions2(void)
429 {
430 #ifdef AFS_NAMEI_ENV
431     DIR *dirp;
432     struct dirent *de;
433     char pname[32];
434     int wouldattach;
435
436     dirp = opendir(OS_DIRSEP);
437     while ((de = readdir(dirp))) {
438         strcpy(pname, OS_DIRSEP);
439         strncat(pname, de->d_name, 20);
440         pname[sizeof(pname) - 1] = '\0';
441
442         /* Only keep track of "/vicepx" partitions since automounter
443          * may hose us */
444         if (VIsAlwaysAttach(pname, &wouldattach)) {
445             VCheckPartition(pname, "", 0);
446         } else {
447             struct afs_stat_st st;
448             if (wouldattach && VGetPartition(pname, 0) == NULL &&
449                 afs_stat(pname, &st) == 0 && S_ISDIR(st.st_mode)) {
450
451                 /* This is a /vicep* dir, and it has not been attached as a
452                  * partition. This probably means that this is a /vicep* dir
453                  * that is not a separate partition, so just give a notice so
454                  * admins are not confused as to why their /vicep* dirs are not
455                  * being attached.
456                  *
457                  * It is possible that the dir _is_ a separate partition and we
458                  * failed to attach it earlier, making this message a bit
459                  * confusing. But that should be rare, and an error message
460                  * about the failure will already be logged right before this,
461                  * so it should be clear enough. */
462
463                 Log("VAttachPartitions: not attaching %s; either it is not a "
464                     "separate partition, or it failed to attach (create the "
465                     "file %s/" VICE_ALWAYSATTACH_FILE " to force attachment)\n",
466                     pname, pname);
467             }
468         }
469     }
470     closedir(dirp);
471 #endif /* AFS_NAMEI_ENV */
472 }
473 #endif /* AFS_NT40_ENV */
474
475 #ifdef AFS_SUN5_ENV
476 int
477 VAttachPartitions(void)
478 {
479     int errors = 0;
480     struct mnttab mnt;
481     FILE *mntfile;
482
483     if (!(mntfile = afs_fopen(MNTTAB, "r"))) {
484         Log("Can't open %s\n", MNTTAB);
485         perror(MNTTAB);
486         exit(-1);
487     }
488     while (!getmntent(mntfile, &mnt)) {
489         int logging = 0;
490         /* Ignore non ufs or non read/write partitions */
491         /* but allow zfs too if we're in the NAMEI environment */
492         if (
493 #ifdef AFS_NAMEI_ENV
494             (((strcmp(mnt.mnt_fstype, "ufs") &&
495                 strcmp(mnt.mnt_fstype, "zfs"))))
496 #else
497             (strcmp(mnt.mnt_fstype, "ufs") != 0)
498 #endif
499             || (strncmp(mnt.mnt_mntopts, "ro,ignore", 9) == 0))
500             continue;
501
502         /* Skip this Partition? */
503         if (VIsNeverAttach(mnt.mnt_mountp))
504             continue;
505
506         /* If we're going to always attach this partition, do it later. */
507         if (VIsAlwaysAttach(mnt.mnt_mountp, NULL))
508             continue;
509
510 #ifndef AFS_NAMEI_ENV
511         if (hasmntopt(&mnt, "logging") != NULL) {
512             logging = 1;
513         }
514 #endif /* !AFS_NAMEI_ENV */
515
516         if (VCheckPartition(mnt.mnt_mountp, mnt.mnt_special, logging) < 0)
517             errors++;
518     }
519
520     (void)fclose(mntfile);
521
522     /* Process the always-attach partitions, if any. */
523     VAttachPartitions2();
524
525     return errors;
526 }
527
528 #endif /* AFS_SUN5_ENV */
529 #if defined(AFS_SGI_ENV) || (defined(AFS_SUN_ENV) && !defined(AFS_SUN5_ENV)) || defined(AFS_HPUX_ENV)
530 int
531 VAttachPartitions(void)
532 {
533     int errors = 0;
534     FILE *mfd;
535     struct mntent *mntent;
536
537     if ((mfd = setmntent(MOUNTED, "r")) == NULL) {
538         Log("Problems in getting mount entries(setmntent)\n");
539         exit(-1);
540     }
541     while (mntent = getmntent(mfd)) {
542         if (!hasmntopt(mntent, MNTOPT_RW))
543             continue;
544
545         /* Skip this Partition? */
546         if (VIsNeverAttach(mntent->mnt_dir))
547             continue;
548
549         /* If we're going to always attach this partition, do it later. */
550         if (VIsAlwaysAttach(mntent->mnt_dir, NULL))
551             continue;
552
553         if (VCheckPartition(mntent->mnt_dir, mntent->mnt_fsname, 0) < 0)
554             errors++;
555     }
556
557     endmntent(mfd);
558
559     /* Process the always-attach partitions, if any. */
560     VAttachPartitions2();
561
562     return errors;
563 }
564 #endif
565 #ifdef AFS_AIX_ENV
566 /*
567  * (This function was grabbed from df.c)
568  */
569 int
570 getmount(struct vmount **vmountpp)
571 {
572     int size;
573     struct vmount *vm;
574     int nmounts;
575
576     /* set initial size of mntctl buffer to a MAGIC NUMBER */
577     size = BUFSIZ;
578
579     /* try the operation until ok or a fatal error */
580     while (1) {
581         if ((vm = malloc(size)) == NULL) {
582             /* failed getting memory for mount status buf */
583             perror("FATAL ERROR: get_stat malloc failed\n");
584             exit(-1);
585         }
586
587         /*
588          * perform the QUERY mntctl - if it returns > 0, that is the
589          * number of vmount structures in the buffer.  If it returns
590          * -1, an error occured.  If it returned 0, then look in
591          * first word of buffer for needed size.
592          */
593         if ((nmounts = mntctl(MCTL_QUERY, size, (caddr_t) vm)) > 0) {
594             /* OK, got it, now return */
595             *vmountpp = vm;
596             return (nmounts);
597
598         } else if (nmounts == 0) {
599             /* the buffer wasn't big enough .... */
600             /* .... get required buffer size */
601             size = *(int *)vm;
602             free(vm);
603
604         } else {
605             /* some other kind of error occurred */
606             free(vm);
607             return (-1);
608         }
609     }
610 }
611
612 int
613 VAttachPartitions(void)
614 {
615     int errors = 0;
616     int nmounts;
617     struct vmount *vmountp;
618
619     if ((nmounts = getmount(&vmountp)) <= 0) {
620         Log("Problems in getting # of mount entries(getmount)\n");
621         exit(-1);
622     }
623     for (; nmounts;
624          nmounts--, vmountp =
625          (struct vmount *)((int)vmountp + vmountp->vmt_length)) {
626         char *part = vmt2dataptr(vmountp, VMT_STUB);
627
628         if (vmountp->vmt_flags & (MNT_READONLY | MNT_REMOVABLE | MNT_REMOTE))
629             continue;           /* Ignore any "special" partitions */
630
631 #ifdef AFS_AIX42_ENV
632 #ifndef AFS_NAMEI_ENV
633         {
634             struct superblock fs;
635             /* The Log statements are non-sequiters in the SalvageLog and don't
636              * even appear in the VolserLog, so restrict them to the FileLog.
637              */
638             if (ReadSuper(&fs, vmt2dataptr(vmountp, VMT_OBJECT)) < 0) {
639                 if (programType == fileServer)
640                     Log("Can't read superblock for %s, ignoring it.\n", part);
641                 continue;
642             }
643             if (IsBigFilesFileSystem(&fs)) {
644                 if (programType == fileServer)
645                     Log("%s is a big files filesystem, ignoring it.\n", part);
646                 continue;
647             }
648         }
649 #endif
650 #endif
651
652         /* Skip this Partition? */
653         if (VIsNeverAttach(part))
654             continue;
655
656         /* If we're going to always attach this partition, do it later. */
657         if (VIsAlwaysAttach(part, NULL))
658             continue;
659
660         if (VCheckPartition(part, vmt2dataptr(vmountp, VMT_OBJECT), 0) < 0)
661             errors++;
662     }
663
664     /* Process the always-attach partitions, if any. */
665     VAttachPartitions2();
666
667     return errors;
668 }
669 #endif
670 #if defined(AFS_DUX40_ENV) || defined(AFS_DARWIN_ENV) || defined(AFS_XBSD_ENV)
671 int
672 VAttachPartitions(void)
673 {
674     int errors = 0;
675     struct fstab *fsent;
676
677     if (setfsent() < 0) {
678         Log("Error listing filesystems.\n");
679         exit(-1);
680     }
681
682     while ((fsent = getfsent())) {
683         if (strcmp(fsent->fs_type, "rw") != 0)
684             continue;
685
686         /* Skip this Partition? */
687         if (VIsNeverAttach(fsent->fs_file))
688             continue;
689
690         /* If we're going to always attach this partition, do it later. */
691         if (VIsAlwaysAttach(fsent->fs_file, NULL))
692             continue;
693
694         if (VCheckPartition(fsent->fs_file, fsent->fs_spec, 0) < 0)
695             errors++;
696     }
697     endfsent();
698
699     /* Process the always-attach partitions, if any. */
700     VAttachPartitions2();
701
702     return errors;
703 }
704 #endif
705
706 #ifdef AFS_NT40_ENV
707 /* VValidVPTEntry
708  *
709  * validate names in vptab.
710  *
711  * Return value:
712  * 1 valid entry
713  * 0 invalid entry
714  */
715
716 static int
717 VValidVPTEntry(struct vptab *vpe)
718 {
719     int len = strlen(vpe->vp_name);
720     int i;
721
722     if (len < VICE_PREFIX_SIZE + 1 || len > VICE_PREFIX_SIZE + 2)
723         return 0;
724     if (strncmp(vpe->vp_name, VICE_PARTITION_PREFIX, VICE_PREFIX_SIZE))
725         return 0;
726
727     for (i = VICE_PREFIX_SIZE; i < len; i++) {
728         if (vpe->vp_name[i] < 'a' || vpe->vp_name[i] > 'z') {
729             Log("Invalid partition name %s in registry, ignoring it.\n",
730                 vpe->vp_name);
731             return 0;
732         }
733     }
734     if (len == VICE_PREFIX_SIZE + 2) {
735         i = (int)(vpe->vp_name[VICE_PREFIX_SIZE] - 'a') * 26 +
736             (int)(vpe->vp_name[VICE_PREFIX_SIZE + 1] - 'a');
737         if (i > 255) {
738             Log("Invalid partition name %s in registry, ignoring it.\n",
739                 vpe->vp_name);
740             return 0;
741         }
742     }
743
744     len = strlen(vpe->vp_dev);
745     if (len != 2 || vpe->vp_dev[1] != ':' || vpe->vp_dev[0] < 'A'
746         || vpe->vp_dev[0] > 'Z') {
747         Log("Invalid device name %s in registry, ignoring it.\n",
748             vpe->vp_dev);
749         return 0;
750     }
751
752     return 1;
753 }
754
755 static int
756 VCheckPartition(char *partName)
757 {
758     char volRoot[4];
759     char volFsType[64];
760     DWORD dwDummy;
761     int err;
762
763     /* partName is presumed to be of the form "X:" */
764     (void)sprintf(volRoot, "%c:\\", *partName);
765
766     if (!GetVolumeInformation(volRoot,  /* volume root directory */
767                               NULL,     /* volume name buffer */
768                               0,        /* volume name size */
769                               NULL,     /* volume serial number */
770                               &dwDummy, /* max component length */
771                               &dwDummy, /* file system flags */
772                               volFsType,        /* file system name */
773                               sizeof(volFsType))) {
774         err = GetLastError();
775         Log("VCheckPartition: Failed to get partition information for %s, ignoring it.\n", partName);
776         return -1;
777     }
778
779     if (strcmp(volFsType, "NTFS")) {
780         Log("VCheckPartition: Partition %s is not an NTFS partition, ignoring it.\n", partName);
781         return -1;
782     }
783
784     return 0;
785 }
786
787
788 int
789 VAttachPartitions(void)
790 {
791     struct DiskPartition64 *partP, *prevP, *nextP;
792     struct vpt_iter iter;
793     struct vptab entry;
794
795     if (vpt_Start(&iter) < 0) {
796         Log("No partitions to attach.\n");
797         return 0;
798     }
799
800     while (0 == vpt_NextEntry(&iter, &entry)) {
801         if (!VValidVPTEntry(&entry)) {
802             continue;
803         }
804
805         /* This test for duplicates relies on the fact that the method
806          * of storing the partition names in the NT registry means the same
807          * partition name will never appear twice in the list.
808          */
809         for (partP = DiskPartitionList; partP; partP = partP->next) {
810             if (*partP->devName == *entry.vp_dev) {
811                 Log("Same drive (%s) used for both partition %s and partition %s, ignoring both.\n", entry.vp_dev, partP->name, entry.vp_name);
812                 partP->flags = PART_DUPLICATE;
813                 break;          /* Only one entry will ever be in this list. */
814             }
815         }
816         if (partP)
817             continue;           /* found a duplicate */
818
819         if (VCheckPartition(entry.vp_dev) < 0)
820             continue;
821         /* This test allows for manually inserting the FORCESALVAGE flag
822          * and thereby invoking the salvager. scandisk obviously won't be
823          * doing this for us.
824          */
825         if (programType == fileServer) {
826             struct afs_stat_st status;
827             char salvpath[MAXPATHLEN];
828             strcpy(salvpath, entry.vp_dev);
829             strcat(salvpath, "\\FORCESALVAGE");
830             if (afs_stat(salvpath, &status) == 0) {
831                 Log("VAttachPartitions: Found %s; aborting\n", salvpath);
832                 exit(1);
833             }
834         }
835         VInitPartition(entry.vp_name, entry.vp_dev, *entry.vp_dev - 'A');
836     }
837     vpt_Finish(&iter);
838
839     /* Run through partition list and clear out the dupes. */
840     prevP = nextP = NULL;
841     for (partP = DiskPartitionList; partP; partP = nextP) {
842         nextP = partP->next;
843         if (partP->flags == PART_DUPLICATE) {
844             if (prevP)
845                 prevP->next = partP->next;
846             else
847                 DiskPartitionList = partP->next;
848             free(partP);
849         } else
850             prevP = partP;
851     }
852
853     return 0;
854 }
855 #endif
856
857 #ifdef AFS_LINUX22_ENV
858 int
859 VAttachPartitions(void)
860 {
861     int errors = 0;
862     FILE *mfd;
863     struct mntent *mntent;
864
865     if ((mfd = setmntent("/proc/mounts", "r")) == NULL) {
866         if ((mfd = setmntent("/etc/mtab", "r")) == NULL) {
867             Log("Problems in getting mount entries(setmntent)\n");
868             exit(-1);
869         }
870     }
871     while ((mntent = getmntent(mfd))) {
872         /* Skip this Partition? */
873         if (VIsNeverAttach(mntent->mnt_dir))
874             continue;
875
876         /* If we're going to always attach this partition, do it later. */
877         if (VIsAlwaysAttach(mntent->mnt_dir, NULL))
878             continue;
879
880         if (VCheckPartition(mntent->mnt_dir, mntent->mnt_fsname, 0) < 0)
881             errors++;
882     }
883     endmntent(mfd);
884
885     /* Process the always-attach partitions, if any. */
886     VAttachPartitions2();
887
888     return errors;
889 }
890 #endif /* AFS_LINUX22_ENV */
891
892 /* This routine is to be called whenever the actual name of the partition
893  * is required. The canonical name is still in part->name.
894  */
895 char *
896 VPartitionPath(struct DiskPartition64 *part)
897 {
898 #ifdef AFS_NT40_ENV
899     return part->devName;
900 #else
901     return part->name;
902 #endif
903 }
904
905 /* get partition structure, abortp tells us if we should abort on failure */
906 struct DiskPartition64 *
907 VGetPartition_r(char *name, int abortp)
908 {
909     struct DiskPartition64 *dp;
910 #ifdef AFS_DEMAND_ATTACH_FS
911     dp = VLookupPartition_r(name);
912 #else /* AFS_DEMAND_ATTACH_FS */
913     for (dp = DiskPartitionList; dp; dp = dp->next) {
914         if (strcmp(dp->name, name) == 0)
915             break;
916     }
917 #endif /* AFS_DEMAND_ATTACH_FS */
918     if (abortp)
919         osi_Assert(dp != NULL);
920     return dp;
921 }
922
923 struct DiskPartition64 *
924 VGetPartition(char *name, int abortp)
925 {
926     struct DiskPartition64 *retVal;
927     VOL_LOCK;
928     retVal = VGetPartition_r(name, abortp);
929     VOL_UNLOCK;
930     return retVal;
931 }
932
933 #ifdef AFS_NT40_ENV
934 void
935 VSetPartitionDiskUsage_r(struct DiskPartition64 *dp)
936 {
937     ULARGE_INTEGER free_user, total, free_total;
938     int ufree, tot, tfree;
939
940     if (!GetDiskFreeSpaceEx
941         (VPartitionPath(dp), &free_user, &total, &free_total)) {
942         printf("Failed to get disk space info for %s, error = %d\n", dp->name,
943                GetLastError());
944         return;
945     }
946
947     /* Convert to 1K units. */
948     ufree = (int)Int64ShraMod32(free_user.QuadPart, 10);
949     tot = (int)Int64ShraMod32(total.QuadPart, 10);
950     tfree = (int)Int64ShraMod32(free_total.QuadPart, 10);
951
952     dp->minFree = tfree - ufree;        /* only used in VPrintDiskStats_r */
953     dp->totalUsable = tot;
954     dp->free = tfree;
955 }
956
957 #else
958 void
959 VSetPartitionDiskUsage_r(struct DiskPartition64 *dp)
960 {
961     int bsize, code;
962     afs_int64 totalblks, free, used, availblks;
963     int reserved;
964 #ifdef afs_statvfs
965     struct afs_statvfs statbuf;
966 #else
967     struct afs_statfs statbuf;
968 #endif
969
970     if (dp->flags & PART_DONTUPDATE)
971         return;
972     /* Note:  we don't bother syncing because it's only an estimate, update
973      * is syncing every 30 seconds anyway, we only have to keep the disk
974      * approximately 10% from full--you just can't get the stuff in from
975      * the net fast enough to worry */
976 #ifdef afs_statvfs
977     code = afs_statvfs(dp->name, &statbuf);
978 #else
979     code = afs_statfs(dp->name, &statbuf);
980 #endif
981     if (code < 0) {
982         Log("statfs of %s failed in VSetPartitionDiskUsage (errno = %d)\n",
983             dp->name, errno);
984         return;
985     }
986     if (statbuf.f_blocks == -1) {       /* Undefined; skip stats.. */
987         Log("statfs of %s failed in VSetPartitionDiskUsage\n", dp->name);
988         return;
989     }
990     totalblks = statbuf.f_blocks;
991     free = statbuf.f_bfree;
992     reserved = free - statbuf.f_bavail;
993 #ifdef afs_statvfs
994     bsize = statbuf.f_frsize;
995 #else
996     bsize = statbuf.f_bsize;
997 #endif
998     availblks = totalblks - reserved;
999     dp->f_files = statbuf.f_files;      /* max # of files in partition */
1000
1001     /* Now free and totalblks are in fragment units, but we want them in
1002      * 1K units.
1003      */
1004     if (bsize >= 1024) {
1005         free *= (bsize / 1024);
1006         totalblks *= (bsize / 1024);
1007         availblks *= (bsize / 1024);
1008         reserved *= (bsize / 1024);
1009     } else {
1010         free /= (1024 / bsize);
1011         totalblks /= (1024 / bsize);
1012         availblks /= (1024 / bsize);
1013         reserved /= (1024 / bsize);
1014     }
1015     /* now compute remaining figures */
1016     used = totalblks - free;
1017
1018     dp->minFree = reserved;     /* only used in VPrintDiskStats_r */
1019     dp->totalUsable = availblks;
1020     dp->free = availblks - used;        /* this is exactly f_bavail */
1021 }
1022 #endif /* AFS_NT40_ENV */
1023
1024 void
1025 VSetPartitionDiskUsage(struct DiskPartition64 *dp)
1026 {
1027     VOL_LOCK;
1028     VSetPartitionDiskUsage_r(dp);
1029     VOL_UNLOCK;
1030 }
1031
1032 void
1033 VResetDiskUsage_r(void)
1034 {
1035     struct DiskPartition64 *dp;
1036     for (dp = DiskPartitionList; dp; dp = dp->next) {
1037         VSetPartitionDiskUsage_r(dp);
1038 #ifndef AFS_PTHREAD_ENV
1039         IOMGR_Poll();
1040 #endif /* !AFS_PTHREAD_ENV */
1041     }
1042 }
1043
1044 void
1045 VResetDiskUsage(void)
1046 {
1047     VOL_LOCK;
1048     VResetDiskUsage_r();
1049     VOL_UNLOCK;
1050 }
1051
1052 void
1053 VAdjustDiskUsage_r(Error * ec, Volume * vp, afs_sfsize_t blocks,
1054                    afs_sfsize_t checkBlocks)
1055 {
1056     *ec = 0;
1057     /* why blocks instead of checkBlocks in the check below?  Otherwise, any check
1058      * for less than BlocksSpare would skip the error-checking path, and we
1059      * could grow existing files forever, not just for another BlocksSpare
1060      * blocks. */
1061     if (blocks > 0) {
1062 #ifdef  AFS_AIX32_ENV
1063         afs_int32 rem, minavail;
1064
1065         if ((rem = vp->partition->free - checkBlocks) < (minavail =
1066                                                          (vp->partition->
1067                                                           totalUsable *
1068                                                           aixlow_water) /
1069                                                          100))
1070 #else
1071         if (vp->partition->free - checkBlocks < 0)
1072 #endif
1073             *ec = VDISKFULL;
1074         else if (V_maxquota(vp)
1075                  && V_diskused(vp) + checkBlocks > V_maxquota(vp))
1076             *ec = VOVERQUOTA;
1077     }
1078     vp->partition->free -= blocks;
1079     V_diskused(vp) += blocks;
1080 }
1081
1082 void
1083 VAdjustDiskUsage(Error * ec, Volume * vp, afs_sfsize_t blocks,
1084                  afs_sfsize_t checkBlocks)
1085 {
1086     VOL_LOCK;
1087     VAdjustDiskUsage_r(ec, vp, blocks, checkBlocks);
1088     VOL_UNLOCK;
1089 }
1090
1091 int
1092 VDiskUsage_r(Volume * vp, afs_sfsize_t blocks)
1093 {
1094     if (blocks > 0) {
1095 #ifdef  AFS_AIX32_ENV
1096         afs_int32 rem, minavail;
1097
1098         if ((rem = vp->partition->free - blocks) < (minavail =
1099                                                     (vp->partition->
1100                                                      totalUsable *
1101                                                      aixlow_water) / 100))
1102 #else
1103         if (vp->partition->free - blocks < 0)
1104 #endif
1105             return (VDISKFULL);
1106     }
1107     vp->partition->free -= blocks;
1108     return 0;
1109 }
1110
1111 int
1112 VDiskUsage(Volume * vp, afs_sfsize_t blocks)
1113 {
1114     int retVal;
1115     VOL_LOCK;
1116     retVal = VDiskUsage_r(vp, blocks);
1117     VOL_UNLOCK;
1118     return retVal;
1119 }
1120
1121 void
1122 VPrintDiskStats_r(void)
1123 {
1124     struct DiskPartition64 *dp;
1125     for (dp = DiskPartitionList; dp; dp = dp->next) {
1126         if (dp->free < 0) {
1127             Log("Partition %s: %lld "
1128                 " available 1K blocks (minfree=%lld), "
1129                 "overallocated by %lld blocks\n", dp->name,
1130                 dp->totalUsable, dp->minFree, -dp->free);
1131         } else {
1132             Log("Partition %s: %lld"
1133                 " available 1K blocks (minfree=%lld), "
1134                 "%lld free blocks\n", dp->name,
1135                 dp->totalUsable, dp->minFree, dp->free);
1136         }
1137     }
1138 }
1139
1140 void
1141 VPrintDiskStats(void)
1142 {
1143     VOL_LOCK;
1144     VPrintDiskStats_r();
1145     VOL_UNLOCK;
1146 }
1147
1148 #ifdef AFS_NT40_ENV
1149 /* Need a separate lock file on NT, since NT only has mandatory file locks. */
1150 #define LOCKFILE "LOCKFILE"
1151 void
1152 VLockPartition_r(char *name)
1153 {
1154     struct DiskPartition64 *dp = VGetPartition_r(name, 0);
1155     OVERLAPPED lap;
1156
1157     if (!dp)
1158         return;
1159     if (dp->lock_fd == INVALID_FD) {
1160         char path[64];
1161         int rc;
1162         (void)sprintf(path, "%s\\%s", VPartitionPath(dp), LOCKFILE);
1163         dp->lock_fd =
1164             (FD_t)CreateFile(path, GENERIC_WRITE,
1165                             FILE_SHARE_READ | FILE_SHARE_WRITE, NULL,
1166                             CREATE_ALWAYS, FILE_ATTRIBUTE_HIDDEN, NULL);
1167         osi_Assert(dp->lock_fd != INVALID_FD);
1168
1169         memset(&lap, 0, sizeof(lap));
1170         rc = LockFileEx((HANDLE) dp->lock_fd, LOCKFILE_EXCLUSIVE_LOCK, 0, 1,
1171                         0, &lap);
1172         osi_Assert(rc);
1173     }
1174 }
1175
1176 void
1177 VUnlockPartition_r(char *name)
1178 {
1179     struct DiskPartition64 *dp = VGetPartition_r(name, 0);
1180     OVERLAPPED lap;
1181
1182     if (!dp)
1183         return;                 /* no partition, will fail later */
1184     memset(&lap, 0, sizeof(lap));
1185
1186     UnlockFileEx((HANDLE) dp->lock_fd, 0, 1, 0, &lap);
1187     CloseHandle((HANDLE) dp->lock_fd);
1188     dp->lock_fd = INVALID_FD;
1189 }
1190 #else /* AFS_NT40_ENV */
1191
1192 #if defined(AFS_HPUX_ENV)
1193 #define BITS_PER_CHAR   (8)
1194 #define BITS(type)      (sizeof(type) * BITS_PER_CHAR)
1195
1196 #define LOCKRDONLY_OFFSET       ((PRIV_LOCKRDONLY - 1) / BITS(int))
1197 #endif /* defined(AFS_HPUX_ENV) */
1198
1199 void
1200 VLockPartition_r(char *name)
1201 {
1202     struct DiskPartition64 *dp = VGetPartition_r(name, 0);
1203     char *partitionName;
1204     int retries, code;
1205     struct timeval pausing;
1206 #if defined(AFS_HPUX_ENV)
1207     int lockfRtn;
1208     struct privgrp_map privGrpList[PRIV_MAXGRPS];
1209     unsigned int *globalMask;
1210     int globalMaskIndex;
1211 #endif /* defined(AFS_HPUX_ENV) */
1212 #if defined(AFS_DARWIN_ENV)
1213     char lockfile[MAXPATHLEN];
1214 #endif /* defined(AFS_DARWIN_ENV) */
1215 #ifdef AFS_NAMEI_ENV
1216 #ifdef AFS_AIX42_ENV
1217     char LockFileName[MAXPATHLEN + 1];
1218
1219     sprintf((char *)&LockFileName, "%s/AFSINODE_FSLock", name);
1220     partitionName = (char *)&LockFileName;
1221 #endif
1222 #endif
1223
1224     if (!dp)
1225         return;                 /* no partition, will fail later */
1226     if (dp->lock_fd != INVALID_FD)
1227         return;
1228
1229 #if    defined(AFS_SUN5_ENV) || defined(AFS_AIX41_ENV)
1230 #if !defined(AFS_AIX42_ENV) || !defined(AFS_NAMEI_ENV)
1231     partitionName = dp->devName;
1232 #endif
1233     code = O_RDWR;
1234 #elif defined(AFS_DARWIN_ENV)
1235     strlcpy((partitionName = lockfile), dp->name, sizeof(lockfile));
1236     strlcat(lockfile, "/.lock.afs", sizeof(lockfile));
1237     code = O_RDONLY | O_CREAT;
1238 #else
1239     partitionName = dp->name;
1240     code = O_RDONLY;
1241 #endif
1242
1243     for (retries = 25; retries; retries--) {
1244         if (code & O_CREAT)
1245             dp->lock_fd = afs_open(partitionName, code, 0644);
1246         else
1247             dp->lock_fd = afs_open(partitionName, code);
1248
1249         if (dp->lock_fd != INVALID_FD)
1250             break;
1251         if (errno == ENOENT)
1252             code |= O_CREAT;
1253         pausing.tv_sec = 0;
1254         pausing.tv_usec = 500000;
1255         select(0, NULL, NULL, NULL, &pausing);
1256     }
1257     osi_Assert(retries != 0);
1258
1259 #if defined (AFS_HPUX_ENV)
1260
1261     osi_Assert(getprivgrp(privGrpList) == 0);
1262
1263     /*
1264      * In general, it will difficult and time-consuming ,if not impossible,
1265      * to try to find the privgroup to which this process belongs that has the
1266      * smallest membership, to minimise the security hole.  So, we use the privgrp
1267      * to which everybody belongs.
1268      */
1269     /* first, we have to find the global mask */
1270     for (globalMaskIndex = 0; globalMaskIndex < PRIV_MAXGRPS;
1271          globalMaskIndex++) {
1272         if (privGrpList[globalMaskIndex].priv_groupno == PRIV_GLOBAL) {
1273             globalMask =
1274                 &(privGrpList[globalMaskIndex].priv_mask[LOCKRDONLY_OFFSET]);
1275             break;
1276         }
1277     }
1278
1279     if (((*globalMask) & privmask(PRIV_LOCKRDONLY)) == 0) {
1280         /* allow everybody to set a lock on a read-only file descriptor */
1281         (*globalMask) |= privmask(PRIV_LOCKRDONLY);
1282         osi_Assert(setprivgrp(PRIV_GLOBAL, privGrpList[globalMaskIndex].priv_mask)
1283                == 0);
1284
1285         lockfRtn = lockf(dp->lock_fd, F_LOCK, 0);
1286
1287         /* remove the privilege granted to everybody to lock a read-only fd */
1288         (*globalMask) &= ~(privmask(PRIV_LOCKRDONLY));
1289         osi_Assert(setprivgrp(PRIV_GLOBAL, privGrpList[globalMaskIndex].priv_mask)
1290                == 0);
1291     } else {
1292         /* in this case, we should be able to do this with impunity, anyway */
1293         lockfRtn = lockf(dp->lock_fd, F_LOCK, 0);
1294     }
1295
1296     osi_Assert(lockfRtn != -1);
1297 #else
1298 #if defined(AFS_AIX_ENV) || defined(AFS_SUN5_ENV)
1299     osi_Assert(lockf(dp->lock_fd, F_LOCK, 0) != -1);
1300 #else
1301     osi_Assert(flock(dp->lock_fd, LOCK_EX) == 0);
1302 #endif /* defined(AFS_AIX_ENV) || defined(AFS_SUN5_ENV) */
1303 #endif
1304 }
1305
1306 void
1307 VUnlockPartition_r(char *name)
1308 {
1309     struct DiskPartition64 *dp = VGetPartition_r(name, 0);
1310     if (!dp)
1311         return;                 /* no partition, will fail later */
1312     close(dp->lock_fd);
1313     dp->lock_fd = INVALID_FD;
1314 }
1315
1316 #endif /* AFS_NT40_ENV */
1317
1318 void
1319 VLockPartition(char *name)
1320 {
1321     VOL_LOCK;
1322     VLockPartition_r(name);
1323     VOL_UNLOCK;
1324 }
1325
1326 void
1327 VUnlockPartition(char *name)
1328 {
1329     VOL_LOCK;
1330     VUnlockPartition_r(name);
1331     VOL_UNLOCK;
1332 }
1333
1334 #ifdef AFS_DEMAND_ATTACH_FS
1335
1336 /* new-style partition locks; these are only to have some mutual exclusion
1337  * between the VGC scanner and volume utilies creating/altering vol headers
1338  */
1339
1340 /**
1341  * lock a partition's vol headers.
1342  *
1343  * @param[in] dp       the partition to lock
1344  * @param[in] locktype READ_LOCK or WRITE_LOCK
1345  *
1346  * @return operation status
1347  *  @retval 0 success
1348  */
1349 int
1350 VPartHeaderLock(struct DiskPartition64 *dp, int locktype)
1351 {
1352     int code;
1353
1354     /* block on acquiring the lock */
1355     int nonblock = 0;
1356
1357     code = VGetDiskLock(&dp->headerLock, locktype, nonblock);
1358     if (code) {
1359         Log("VPartHeaderLock: error %d locking partititon %s\n", code,
1360             VPartitionPath(dp));
1361     }
1362     return code;
1363 }
1364
1365 /**
1366  * unlock a partition's vol headers.
1367  *
1368  * @param[in] dp       the partition to unlock
1369  * @param[in] locktype READ_LOCK or WRITE_LOCK
1370  */
1371 void
1372 VPartHeaderUnlock(struct DiskPartition64 *dp, int locktype)
1373 {
1374     VReleaseDiskLock(&dp->headerLock, locktype);
1375 }
1376
1377 /* XXX not sure this will work on AFS_NT40_ENV
1378  * needs to be tested!
1379  */
1380
1381 /**
1382  * lookup a disk partition object by its index number.
1383  *
1384  * @param[in] id      partition index number
1385  * @param[in] abortp  see abortp usage note below
1386  *
1387  * @return disk partition object
1388  *   @retval NULL no such disk partition
1389  *
1390  * @note when abortp is non-zero, lookups which would return
1391  *       NULL will result in an assertion failure
1392  *
1393  * @pre VOL_LOCK must be held
1394  *
1395  * @internal volume package internal use only
1396  */
1397
1398 struct DiskPartition64 *
1399 VGetPartitionById_r(afs_int32 id, int abortp)
1400 {
1401     struct DiskPartition64 *dp = NULL;
1402
1403     if ((id >= 0) && (id <= VOLMAXPARTS)) {
1404         dp = DiskPartitionTable[id];
1405     }
1406
1407     if (abortp) {
1408         osi_Assert(dp != NULL);
1409     }
1410     return dp;
1411 }
1412
1413 /**
1414  * lookup a disk partition object by its index number.
1415  *
1416  * @param[in] id      partition index number
1417  * @param[in] abortp  see abortp usage note below
1418  *
1419  * @return disk partition object
1420  *   @retval NULL no such disk partition
1421  *
1422  * @note when abortp is non-zero, lookups which would return
1423  *       NULL will result in an assertion failure
1424  */
1425
1426 struct DiskPartition64 *
1427 VGetPartitionById(afs_int32 id, int abortp)
1428 {
1429     struct DiskPartition64 * dp;
1430
1431     VOL_LOCK;
1432     dp = VGetPartitionById_r(id, abortp);
1433     VOL_UNLOCK;
1434
1435     return dp;
1436 }
1437
1438 static struct DiskPartition64 *
1439 VLookupPartition_r(char * path)
1440 {
1441     afs_int32 id = volutil_GetPartitionID(path);
1442
1443     if (id < 0 || id > VOLMAXPARTS)
1444         return NULL;
1445
1446     return DiskPartitionTable[id];
1447 }
1448
1449 static void
1450 AddPartitionToTable_r(struct DiskPartition64 *dp)
1451 {
1452     osi_Assert(dp->index >= 0 && dp->index <= VOLMAXPARTS);
1453     DiskPartitionTable[dp->index] = dp;
1454 }
1455
1456 #if 0
1457 static void
1458 DeletePartitionFromTable_r(struct DiskPartition64 *dp)
1459 {
1460     osi_Assert(dp->index >= 0 && dp->index <= VOLMAXPARTS);
1461     DiskPartitionTable[dp->index] = NULL;
1462 }
1463 #endif
1464 #endif /* AFS_DEMAND_ATTACH_FS */