2 * Copyright 2000, International Business Machines Corporation and others.
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
15 * afs_CheckVolumeNames
18 #include <afsconfig.h>
19 #include "afs/param.h"
23 #include "afs/sysincludes.h" /* Standard vendor system headers */
26 #if !defined(AFS_LINUX20_ENV)
29 #include <netinet/in.h>
32 #include "h/hashing.h"
34 #if !defined(AFS_HPUX110_ENV) && !defined(AFS_LINUX20_ENV) && !defined(AFS_DARWIN_ENV)
35 #include <netinet/in_var.h>
36 #endif /* ! AFS_HPUX110_ENV */
37 #endif /* !defined(UKERNEL) */
39 #include "afsincludes.h" /* Afs-based standard headers */
40 #include "afs/afs_stats.h" /* afs statistics */
41 #include "afs/afs_dynroot.h"
43 #if defined(AFS_SUN5_ENV)
45 #include <inet/common.h>
46 #include <netinet/ip6.h>
50 /* In case we don't have the vl error table yet. */
51 #ifndef ERROR_TABLE_BASE_VL
52 #define ERROR_TABLE_BASE_VL (363520L)
53 #define VL_NOENT (363524L)
54 #endif /* vlserver error base define */
56 /* Exported variables */
57 afs_int32 afs_volume_ttl = 0;
58 afs_dcache_id_t volumeInode; /* Inode for VolumeItems file */
59 afs_rwlock_t afs_xvolume; /** allocation lock for volumes */
60 struct volume *afs_freeVolList;
61 struct volume *afs_volumes[NVOLS];
62 afs_int32 afs_volCounter = 1; /** for allocating volume indices */
63 afs_int32 fvTable[NFENTRIES];
65 /* Forward declarations */
66 static struct volume *afs_NewVolumeByName(char *aname, afs_int32 acell,
67 int agood, struct vrequest *areq,
69 static struct volume *afs_NewDynrootVolume(struct VenusFid *fid);
70 static int inVolList(struct VenusFid *fid, afs_int32 nvols, afs_int32 * vID,
76 * Convert a volume name to a number;
77 * @param aname Volume name.
78 * @return return 0 if can't parse as a number.
86 AFS_STATCNT(afs_vtoi);
87 while ((tc = *aname++)) {
88 if (tc > '9' || tc < '0')
89 return 0; /* invalid name */
99 * All of the vol cache routines must be called with the afs_xvolume
100 * lock held in exclusive mode, since they use static variables.
101 * In addition, we don't want two people adding the same volume
105 static struct fvolume staticFVolume;
106 afs_int32 afs_FVIndex = -1;
109 * Initialize a newly gotten volume slot.
111 * \param tv volume slot to be initialized
112 * \param tf volume item data; null if none
113 * \param volid volume id for this volume slot
114 * \param cell cell for this volume slot
118 afs_InitVolSlot(struct volume *tv, struct fvolume *tf, afs_int32 volid,
121 AFS_STATCNT(afs_InitVolSlot);
122 memset(tv, 0, sizeof(struct volume));
123 tv->cell = tcell->cellNum;
124 AFS_RWLOCK_INIT(&tv->lock, "volume lock");
127 tv->vtix = afs_FVIndex;
128 tv->mtpoint = tf->mtpoint;
129 tv->dotdot = tf->dotdot;
130 tv->rootVnode = tf->rootVnode;
131 tv->rootUnique = tf->rootUnique;
134 tv->rootVnode = tv->rootUnique = 0;
135 afs_GetDynrootMountFid(&tv->dotdot);
136 afs_GetDynrootMountFid(&tv->mtpoint);
137 tv->mtpoint.Fid.Vnode =
138 VNUM_FROM_TYPEID(VN_TYPE_MOUNT, tcell->cellIndex << 2);
139 tv->mtpoint.Fid.Unique = volid;
144 * UFS specific version of afs_GetVolSlot
148 afs_UFSGetVolSlot(afs_int32 volid, struct cell *tcell)
150 struct volume *tv = NULL, **lv;
151 struct osi_file *tfile;
152 afs_int32 i = -1, code;
154 struct volume *bestVp, *oldLp = NULL, **bestLp = NULL;
155 char *oldname = NULL;
156 afs_int32 oldvtix = -2; /* Initialize to a value that doesn't occur */
157 struct fvolume *tf = NULL;
160 AFS_STATCNT(afs_UFSGetVolSlot);
161 if (!afs_freeVolList) {
163 bestTime = 0x7fffffff;
166 for (i = 0; i < NVOLS; i++) {
167 lv = &afs_volumes[i];
168 for (tv = *lv; tv; lv = &tv->next, tv = *lv) {
169 if (tv->refCount == 0) { /* is this one available? */
170 if (tv->setupTime < bestTime) { /* best one available? */
171 bestTime = tv->setupTime;
179 afs_warn("afs_UFSGetVolSlot: no vol slots available\n");
191 /* now write out volume structure to file */
193 tv->vtix = afs_volCounter++;
194 /* now put on hash chain */
195 i = FVHash(tv->cell, tv->volume);
196 staticFVolume.next = fvTable[i];
197 fvTable[i] = tv->vtix;
200 * Haul the guy in from disk so we don't overwrite hash table
203 if (afs_FVIndex != tv->vtix) {
204 tfile = osi_UFSOpen(&volumeInode);
206 afs_warn("afs_UFSGetVolSlot: unable to open volumeinfo\n");
210 afs_osi_Read(tfile, sizeof(struct fvolume) * tv->vtix,
211 &staticFVolume, sizeof(struct fvolume));
213 if (code != sizeof(struct fvolume)) {
214 afs_warn("afs_UFSGetVolSlot: error %d reading volumeinfo\n",
220 afs_FVIndex = tv->vtix;
221 staticFVolume.volume = tv->volume;
222 staticFVolume.cell = tv->cell;
223 staticFVolume.mtpoint = tv->mtpoint;
224 staticFVolume.dotdot = tv->dotdot;
225 staticFVolume.rootVnode = tv->rootVnode;
226 staticFVolume.rootUnique = tv->rootUnique;
227 tfile = osi_UFSOpen(&volumeInode);
229 afs_warn("afs_UFSGetVolSlot: unable to open volumeinfo\n");
233 afs_osi_Write(tfile, sizeof(struct fvolume) * afs_FVIndex,
234 &staticFVolume, sizeof(struct fvolume));
236 if (code != sizeof(struct fvolume)) {
237 afs_warn("afs_UFSGetVolSlot: error %d writing volumeinfo\n",
242 afs_osi_Free(oldname, strlen(oldname) + 1);
246 tv = afs_freeVolList;
247 afs_freeVolList = tv->next;
250 /* read volume item data from disk for the gotten slot */
251 for (j = fvTable[FVHash(tcell->cellNum, volid)]; j != 0; j = staticFVolume.next) {
252 if (afs_FVIndex != j) {
253 /* The data in staticFVolume is currently for a different slot.
254 * Read the data for slot 'j' into staticFVolume. */
255 tfile = osi_UFSOpen(&volumeInode);
257 afs_warn("afs_UFSGetVolSlot: unable to open volumeinfo\n");
258 code = -1; /* indicate error */
261 afs_osi_Read(tfile, sizeof(struct fvolume) * j,
262 &staticFVolume, sizeof(struct fvolume));
264 if (code != sizeof(struct fvolume)) {
265 afs_warn("afs_UFSGetVolSlot: error %d reading volumeinfo\n",
269 if (code != sizeof(struct fvolume)) {
270 /* put tv back on the free list; the data in it is not valid */
271 tv->next = afs_freeVolList;
272 afs_freeVolList = tv;
273 /* staticFVolume contents are not valid */
279 if (staticFVolume.cell == tcell->cellNum && staticFVolume.volume == volid) {
285 afs_InitVolSlot(tv, tf, volid, tcell);
291 afs_warn("afs_UFSGetVolSlot: oldvtix is uninitialized\n");
300 fvTable[i] = staticFVolume.next;
306 /* we messed with staticFVolume, so make sure someone else
307 * doesn't think it's fine to use */
311 } /*afs_UFSGetVolSlot */
315 * Get an available volume list slot. If the list does not exist,
316 * create one containing a single element.
320 afs_MemGetVolSlot(afs_int32 volid, struct cell *tcell)
324 AFS_STATCNT(afs_MemGetVolSlot);
325 if (!afs_freeVolList) {
326 struct volume *newVp;
328 newVp = afs_osi_Alloc(sizeof(struct volume));
329 osi_Assert(newVp != NULL);
332 afs_freeVolList = newVp;
334 tv = afs_freeVolList;
335 afs_freeVolList = tv->next;
337 afs_InitVolSlot(tv, NULL, volid, tcell);
340 } /*afs_MemGetVolSlot */
343 * Setup a volume slot for cell:volume.
345 * Find the volume slot for the cell:volume, otherwise get
346 * and initialize a new slot.
348 * \param volid volume id
352 static struct volume *
353 afs_SetupVolSlot(afs_int32 volid, struct cell *tcell)
358 AFS_STATCNT(afs_SetupVolSlot);
359 ObtainWriteLock(&afs_xvolume, 108);
361 for (tv = afs_volumes[i]; tv; tv = tv->next) {
362 if (tv->volume == volid && tv->cell == tcell->cellNum) {
367 tv = afs_GetVolSlot(volid, tcell);
369 ReleaseWriteLock(&afs_xvolume);
372 tv->next = afs_volumes[i]; /* thread into list */
376 tv->states &= ~VRecheck; /* just checked it */
377 tv->setupTime = osi_Time();
378 ReleaseWriteLock(&afs_xvolume);
383 * Reset volume information for all volume structs that
384 * point to a speicific server, skipping a given volume if provided.
387 * The server to reset volume info about
389 * The volume to skip resetting info about
392 afs_ResetVolumes(struct server *srvp, struct volume *tv)
397 /* Find any volumes residing on this server and flush their state */
398 for (j = 0; j < NVOLS; j++) {
399 for (vp = afs_volumes[j]; vp; vp = vp->next) {
400 for (k = 0; k < AFS_MAXHOSTS; k++) {
401 if (!srvp || (vp->serverHost[k] == srvp)) {
402 if (tv && tv != vp) {
403 vp->serverHost[k] = 0;
404 afs_ResetVolumeInfo(vp);
414 * Returns non-zero if the volume information is expired.
416 * Dynroot volumes are not setup from vldb queries, so never expire.
417 * Read-only volume expiry is tied to the volume callback.
419 * Optionally, invalidate volume information after a fixed timeout.
420 * The vlservers will be periodically probed for volume information.
421 * This avoids a situation where the vldb information is cached
422 * indefinitely as long as files in the volume are accessed (and are
423 * not in the vcache) before the callback expires.
425 * \param tv volume to check
426 * \param now current time
428 * \return non-zero if the volume should be reset
431 IsExpired(struct volume *tv, afs_int32 now)
433 if (afs_IsDynrootVolume(tv)) {
436 if ((tv->states & VRO) && (tv->expireTime < (now + 10))) {
439 if ((afs_volume_ttl != 0) && ((tv->setupTime + afs_volume_ttl) < now)) {
446 * Reset volume name to volume id mapping cache.
450 afs_CheckVolumeNames(int flags)
456 afs_int32 *volumeID, *cellID, vsize, nvols;
457 #ifdef AFS_DARWIN80_ENV
460 AFS_STATCNT(afs_CheckVolumeNames);
463 volumeID = cellID = NULL;
465 ObtainReadLock(&afs_xvolume);
466 if (flags & AFS_VOLCHECK_EXPIRED) {
468 * allocate space to hold the volumeIDs and cellIDs, only if
469 * we will be invalidating the mountpoints later on
471 for (i = 0; i < NVOLS; i++)
472 for (tv = afs_volumes[i]; tv; tv = tv->next)
475 volumeID = afs_osi_Alloc(2 * vsize * sizeof(*volumeID));
476 cellID = (volumeID) ? volumeID + vsize : 0;
480 for (i = 0; i < NVOLS; i++) {
481 for (tv = afs_volumes[i]; tv; tv = tv->next) {
482 if (flags & AFS_VOLCHECK_EXPIRED) {
483 if (IsExpired(tv, now) || (flags & AFS_VOLCHECK_FORCE)) {
484 afs_ResetVolumeInfo(tv); /* also resets status */
486 volumeID[nvols] = tv->volume;
487 cellID[nvols] = tv->cell;
494 if (flags & (AFS_VOLCHECK_BUSY | AFS_VOLCHECK_FORCE)) {
495 for (j = 0; j < AFS_MAXHOSTS; j++)
496 tv->status[j] = not_busy;
501 ReleaseReadLock(&afs_xvolume);
504 /* next ensure all mt points are re-evaluated */
505 if (nvols || (flags & (AFS_VOLCHECK_FORCE | AFS_VOLCHECK_MTPTS))) {
507 ObtainReadLock(&afs_xvcache);
508 for (i = 0; i < VCSIZE; i++) {
509 for (tvc = afs_vhashT[i]; tvc; tvc = tvc->hnext) {
511 /* if the volume of "mvid.target_root" of the vcache entry is
512 * among the ones we found earlier, then we re-evaluate it.
513 * Also, if the force bit is set or we explicitly asked to
514 * reevaluate the mt-pts, we clean the cmvalid bit */
516 if ((flags & (AFS_VOLCHECK_FORCE | AFS_VOLCHECK_MTPTS))
517 || (tvc->mvid.target_root
518 && inVolList(tvc->mvid.target_root, nvols, volumeID, cellID)))
519 tvc->f.states &= ~CMValid;
521 /* If the volume that this file belongs to was reset earlier,
522 * then we should remove its callback.
523 * Again, if forced, always do it.
525 if ((tvc->f.states & CRO)
526 && (inVolList(&tvc->f.fid, nvols, volumeID, cellID)
527 || (flags & AFS_VOLCHECK_FORCE))) {
529 if (tvc->f.states & CVInit) {
530 ReleaseReadLock(&afs_xvcache);
531 afs_osi_Sleep(&tvc->f.states);
534 #ifdef AFS_DARWIN80_ENV
535 if (tvc->f.states & CDeadVnode) {
536 ReleaseReadLock(&afs_xvcache);
537 afs_osi_Sleep(&tvc->f.states);
543 if (vnode_ref(tvp)) {
545 /* AFSTOV(tvc) may be NULL */
551 if (osi_vnhold(tvc) != 0) {
555 ReleaseReadLock(&afs_xvcache);
557 /* LOCKXXX: We aren't holding tvc write lock? */
558 afs_StaleVCache(tvc);
560 #ifdef AFS_DARWIN80_ENV
561 vnode_put(AFSTOV(tvc));
562 /* our tvc ptr is still good until now */
564 ObtainReadLock(&afs_xvcache);
566 ObtainReadLock(&afs_xvcache);
568 /* our tvc ptr is still good until now */
574 osi_dnlc_purge(); /* definitely overkill, but it's safer this way. */
575 ReleaseReadLock(&afs_xvcache);
579 afs_osi_Free(volumeID, 2 * vsize * sizeof(*volumeID));
581 } /*afs_CheckVolumeNames */
585 * Check if volume is in the specified list.
586 * @param fid File FID.
587 * @param nvols Nomber of volumes???
588 * @param vID Array of volume IDs.
589 * @param cID Array of cache IDs.
590 * @return 1 - true, 0 - false.
593 inVolList(struct VenusFid *fid, afs_int32 nvols, afs_int32 * vID,
598 /* if no arrays present, be conservative and return true */
599 if (nvols && (!vID || !cID))
602 for (i = 0; i < nvols; ++i) {
603 if (fid->Fid.Volume == vID[i] && fid->Cell == cID[i])
610 /* afs_PutVolume is now a macro in afs.h */
614 * Return volume struct if we have it cached and it's up-to-date.
615 * Environment: Must be called with afs_xvolume unlocked.
616 * @param afid Volume FID.
618 * @return Volume or NULL if no result.
621 afs_FindVolume(struct VenusFid *afid, afs_int32 locktype)
629 i = VHash(afid->Fid.Volume);
630 ObtainWriteLock(&afs_xvolume, 106);
631 for (tv = afs_volumes[i]; tv; tv = tv->next) {
632 if (tv->volume == afid->Fid.Volume && tv->cell == afid->Cell
633 && (tv->states & VRecheck) == 0) {
638 ReleaseWriteLock(&afs_xvolume);
639 return tv; /* NULL if we didn't find it */
640 } /*afs_FindVolume */
645 * Note that areq may be null, in which case we don't bother to set any
646 * request status information.
647 * @param afid Volume FID.
648 * @param areq Request type.
649 * @param locktype Lock to be used.
650 * @return Volume or NULL if no result.
653 afs_GetVolume(struct VenusFid *afid, struct vrequest *areq,
657 char *bp, tbuf[CVBS];
658 AFS_STATCNT(afs_GetVolume);
660 tv = afs_FindVolume(afid, locktype);
662 /* Do a dynroot check and add dynroot volume if found. */
663 if (afs_IsDynrootAnyFid(afid)) {
664 tv = afs_NewDynrootVolume(afid);
666 bp = afs_cv2string(&tbuf[CVBS], afid->Fid.Volume);
667 tv = afs_NewVolumeByName(bp, afid->Cell, 0, areq, locktype);
677 * @param volid Volume ID. If it's 0, get it from the name.
678 * @param aname Volume name.
679 * @param ve Volume entry.
680 * @param tcell The cell containing this volume.
682 * @param type Type of volume.
683 * @param areq Request.
684 * @return Volume or NULL if failure.
686 static struct volume *
687 afs_SetupVolume(afs_int32 volid, char *aname, void *ve, struct cell *tcell,
688 afs_int32 agood, afs_int32 type, struct vrequest *areq)
691 struct vldbentry *ove = (struct vldbentry *)ve;
692 struct nvldbentry *nve = (struct nvldbentry *)ve;
693 struct uvldbentry *uve = (struct uvldbentry *)ve;
695 int whichType; /* which type of volume to look for */
700 /* special hint from file server to use vlserver */
702 if (len >= 8 && strcmp(aname + len - 7, ".backup") == 0)
704 else if (len >= 10 && strcmp(aname + len - 9, ".readonly") == 0)
709 /* figure out which one we're really interested in (a set is returned) */
710 volid = afs_vtoi(aname);
713 volid = uve->volumeId[whichType];
714 } else if (type == 1) {
715 volid = nve->volumeId[whichType];
717 volid = ove->volumeId[whichType];
719 } /* end of if (volid == 0) */
720 } /* end of if (!volid) */
722 tv = afs_SetupVolSlot(volid, tcell);
728 LockAndInstallUVolumeEntry(tv, uve, tcell->cellNum, tcell, areq);
729 } else if (type == 1)
730 LockAndInstallNVolumeEntry(tv, nve, tcell->cellNum);
732 LockAndInstallVolumeEntry(tv, ove, tcell->cellNum);
735 tv->name = afs_osi_Alloc(strlen(aname) + 1);
736 osi_Assert(tv->name != NULL);
737 strcpy(tv->name, aname);
740 for (i = 0; i < NMAXNSERVERS; i++) {
741 tv->status[i] = not_busy;
743 ReleaseWriteLock(&tv->lock);
749 * Seek volume by it's name and attributes.
750 * If volume not found, try to add one.
751 * @param aname Volume name.
755 * @param locktype Type of lock to be used.
759 afs_GetVolumeByName(char *aname, afs_int32 acell, int agood,
760 struct vrequest *areq, afs_int32 locktype)
765 AFS_STATCNT(afs_GetVolumeByName);
766 ObtainWriteLock(&afs_xvolume, 112);
767 for (i = 0; i < NVOLS; i++) {
768 for (tv = afs_volumes[i]; tv; tv = tv->next) {
769 if (tv->name && !strcmp(aname, tv->name) && tv->cell == acell
770 && (tv->states & VRecheck) == 0) {
772 ReleaseWriteLock(&afs_xvolume);
778 ReleaseWriteLock(&afs_xvolume);
780 if (AFS_IS_DISCONNECTED)
783 tv = afs_NewVolumeByName(aname, acell, agood, areq, locktype);
788 * Init a new dynroot volume.
790 * @return Volume or NULL if not found.
792 static struct volume *
793 afs_NewDynrootVolume(struct VenusFid *fid)
797 struct vldbentry *tve;
798 char *bp, tbuf[CVBS];
800 tcell = afs_GetCell(fid->Cell, READ_LOCK);
803 tve = afs_osi_Alloc(sizeof(*tve));
804 osi_Assert(tve != NULL);
805 if (!(tcell->states & CHasVolRef))
806 tcell->states |= CHasVolRef;
808 bp = afs_cv2string(&tbuf[CVBS], fid->Fid.Volume);
809 memset(tve, 0, sizeof(*tve));
810 strcpy(tve->name, "local-dynroot");
811 tve->volumeId[ROVOL] = fid->Fid.Volume;
812 tve->flags = VLF_ROEXISTS;
814 tv = afs_SetupVolume(0, bp, tve, tcell, 0, 0, 0);
815 afs_PutCell(tcell, READ_LOCK);
816 afs_osi_Free(tve, sizeof(*tve));
823 * @param aname Volume name.
824 * @param acell Cell id.
826 * @param areq Request type.
827 * @param locktype Type of lock to be used.
828 * @return Volume or NULL if failure.
830 static struct volume *
831 afs_NewVolumeByName(char *aname, afs_int32 acell, int agood,
832 struct vrequest *areq, afs_int32 locktype)
834 afs_int32 code, type = 0;
835 struct volume *tv, *tv1;
836 struct vldbentry *tve;
837 struct nvldbentry *ntve;
838 struct uvldbentry *utve;
841 struct afs_conn *tconn;
842 struct vrequest *treq = NULL;
843 struct rx_connection *rxconn;
845 if (strlen(aname) > VL_MAXNAMELEN) /* Invalid volume name */
848 tcell = afs_GetCell(acell, READ_LOCK);
853 code = afs_CreateReq(&treq, afs_osi_credp); /* *must* be unauth for vldb */
858 /* allow null request if we don't care about ENODEV/ETIMEDOUT distinction */
863 afs_Trace2(afs_iclSetp, CM_TRACE_GETVOL, ICL_TYPE_STRING, aname,
864 ICL_TYPE_POINTER, aname);
865 tbuffer = osi_AllocLargeSpace(AFS_LRALLOCSIZ);
866 tve = (struct vldbentry *)(tbuffer + 1024);
867 ntve = (struct nvldbentry *)tve;
868 utve = (struct uvldbentry *)tve;
872 afs_ConnByMHosts(tcell->cellHosts, tcell->vlport, tcell->cellNum,
873 treq, SHARED_LOCK, 0, &rxconn);
875 if (tconn->parent->srvr->server->flags & SNO_LHOSTS) {
878 code = VL_GetEntryByNameO(rxconn, aname, tve);
880 } else if (tconn->parent->srvr->server->flags & SYES_LHOSTS) {
883 code = VL_GetEntryByNameN(rxconn, aname, ntve);
888 code = VL_GetEntryByNameU(rxconn, aname, utve);
890 if (!(tconn->parent->srvr->server->flags & SVLSRV_UUID)) {
891 if (code == RXGEN_OPCODE) {
894 code = VL_GetEntryByNameN(rxconn, aname, ntve);
896 if (code == RXGEN_OPCODE) {
898 tconn->parent->srvr->server->flags |= SNO_LHOSTS;
900 code = VL_GetEntryByNameO(rxconn, aname, tve);
903 tconn->parent->srvr->server->flags |= SYES_LHOSTS;
905 tconn->parent->srvr->server->flags |= SVLSRV_UUID;
911 } while (afs_Analyze(tconn, rxconn, code, NULL, treq, -1, /* no op code for this */
912 SHARED_LOCK, tcell));
915 afs_CopyError(treq, areq);
916 osi_FreeLargeSpace(tbuffer);
917 afs_PutCell(tcell, READ_LOCK);
918 afs_DestroyReq(treq);
922 * Check to see if this cell has not yet referenced a volume. If
923 * it hasn't, it's just about to change its status, and we need to mark
924 * this fact down. Note that it is remotely possible that afs_SetupVolume
925 * could fail and we would still not have a volume reference.
927 if (!(tcell->states & CHasVolRef)) {
928 tcell->states |= CHasVolRef;
929 afs_stats_cmperf.numCellsContacted++;
931 /*First time a volume in this cell has been referenced */
938 tv = afs_SetupVolume(0, aname, ve, tcell, agood, type, treq);
939 if ((agood == 3) && tv && tv->backVol) {
941 * This means that very soon we'll ask for the BK volume so
942 * we'll prefetch it (well we did already.)
945 afs_SetupVolume(tv->backVol, (char *)0, ve, tcell, 0, type, treq);
950 if ((agood >= 2) && tv && tv->roVol) {
952 * This means that very soon we'll ask for the RO volume so
953 * we'll prefetch it (well we did already.)
955 tv1 = afs_SetupVolume(tv->roVol, NULL, ve, tcell, 0, type, treq);
960 osi_FreeLargeSpace(tbuffer);
961 afs_PutCell(tcell, READ_LOCK);
962 afs_DestroyReq(treq);
965 } /*afs_NewVolumeByName */
970 * Call this with the volume structure locked; used for new-style vldb requests.
976 LockAndInstallVolumeEntry(struct volume *av, struct vldbentry *ve, int acell)
984 struct server *serverHost[AFS_MAXHOSTS];
986 AFS_STATCNT(InstallVolumeEntry);
988 memset(serverHost, 0, sizeof(serverHost));
990 /* Determine the type of volume we want */
991 if ((ve->flags & VLF_RWEXISTS) && (av->volume == ve->volumeId[RWVOL])) {
993 } else if ((ve->flags & VLF_ROEXISTS)
994 && (av->volume == ve->volumeId[ROVOL])) {
997 } else if ((ve->flags & VLF_BACKEXISTS)
998 && (av->volume == ve->volumeId[BACKVOL])) {
999 /* backup always is on the same volume as parent */
1001 types |= (VRO | VBackup);
1003 mask = 0; /* Can't find volume in vldb entry */
1006 cellp = afs_GetCell(acell, 0);
1008 /* Step through the VLDB entry making sure each server listed is there */
1009 for (i = 0, j = 0; i < ve->nServers; i++) {
1010 if (((ve->serverFlags[i] & mask) == 0)
1011 || (ve->serverFlags[i] & VLSF_DONTUSE)) {
1012 continue; /* wrong volume or don't use this volume */
1015 temp = htonl(ve->serverNumber[i]);
1016 ts = afs_GetServer(&temp, 1, acell, cellp->fsport, WRITE_LOCK,
1017 (afsUUID *) 0, 0, av);
1021 * The cell field could be 0 if the server entry was created
1022 * first with the 'fs setserverprefs' call which doesn't set
1023 * the cell field. Thus if the afs_GetServer call above
1024 * follows later on it will find the server entry thus it will
1025 * simply return without setting any fields, so we set the
1026 * field ourselves below.
1030 afs_PutServer(ts, WRITE_LOCK);
1034 ObtainWriteLock(&av->lock, 109);
1036 memcpy(av->serverHost, serverHost, sizeof(serverHost));
1039 av->states |= types;
1041 /* fill in volume types */
1042 av->rwVol = ((ve->flags & VLF_RWEXISTS) ? ve->volumeId[RWVOL] : 0);
1043 av->roVol = ((ve->flags & VLF_ROEXISTS) ? ve->volumeId[ROVOL] : 0);
1044 av->backVol = ((ve->flags & VLF_BACKEXISTS) ? ve->volumeId[BACKVOL] : 0);
1046 if (ve->flags & VLF_DFSFILESET)
1047 av->states |= VForeign;
1049 afs_SortServers(av->serverHost, AFS_MAXHOSTS);
1050 } /*InstallVolumeEntry */
1054 LockAndInstallNVolumeEntry(struct volume *av, struct nvldbentry *ve, int acell)
1062 struct server *serverHost[AFS_MAXHOSTS];
1064 AFS_STATCNT(InstallVolumeEntry);
1066 memset(serverHost, 0, sizeof(serverHost));
1068 /* Determine type of volume we want */
1069 if ((ve->flags & VLF_RWEXISTS) && (av->volume == ve->volumeId[RWVOL])) {
1071 } else if ((ve->flags & VLF_ROEXISTS)
1072 && (av->volume == ve->volumeId[ROVOL])) {
1075 } else if ((ve->flags & VLF_BACKEXISTS)
1076 && (av->volume == ve->volumeId[BACKVOL])) {
1077 /* backup always is on the same volume as parent */
1079 types |= (VRO | VBackup);
1081 mask = 0; /* Can't find volume in vldb entry */
1084 cellp = afs_GetCell(acell, 0);
1086 /* Step through the VLDB entry making sure each server listed is there */
1087 for (i = 0, j = 0; i < ve->nServers; i++) {
1088 if (((ve->serverFlags[i] & mask) == 0)
1089 || (ve->serverFlags[i] & VLSF_DONTUSE)) {
1090 continue; /* wrong volume or don't use this volume */
1093 temp = htonl(ve->serverNumber[i]);
1094 ts = afs_GetServer(&temp, 1, acell, cellp->fsport, WRITE_LOCK,
1095 (afsUUID *) 0, 0, av);
1098 * The cell field could be 0 if the server entry was created
1099 * first with the 'fs setserverprefs' call which doesn't set
1100 * the cell field. Thus if the afs_GetServer call above
1101 * follows later on it will find the server entry thus it will
1102 * simply return without setting any fields, so we set the
1103 * field ourselves below.
1107 afs_PutServer(ts, WRITE_LOCK);
1111 ObtainWriteLock(&av->lock, 110);
1113 memcpy(av->serverHost, serverHost, sizeof(serverHost));
1116 av->states |= types;
1118 /* fill in volume types */
1119 av->rwVol = ((ve->flags & VLF_RWEXISTS) ? ve->volumeId[RWVOL] : 0);
1120 av->roVol = ((ve->flags & VLF_ROEXISTS) ? ve->volumeId[ROVOL] : 0);
1121 av->backVol = ((ve->flags & VLF_BACKEXISTS) ? ve->volumeId[BACKVOL] : 0);
1123 if (ve->flags & VLF_DFSFILESET)
1124 av->states |= VForeign;
1126 afs_SortServers(av->serverHost, AFS_MAXHOSTS);
1127 } /*InstallNVolumeEntry */
1131 LockAndInstallUVolumeEntry(struct volume *av, struct uvldbentry *ve, int acell,
1132 struct cell *tcell, struct vrequest *areq)
1135 struct afs_conn *tconn;
1138 afs_uint32 serverid;
1142 struct server *serverHost[AFS_MAXHOSTS];
1144 AFS_STATCNT(InstallVolumeEntry);
1146 memset(serverHost, 0, sizeof(serverHost));
1148 /* Determine type of volume we want */
1149 if ((ve->flags & VLF_RWEXISTS) && (av->volume == ve->volumeId[RWVOL])) {
1151 } else if ((ve->flags & VLF_ROEXISTS)
1152 && av->volume == ve->volumeId[ROVOL]) {
1155 } else if ((ve->flags & VLF_BACKEXISTS)
1156 && (av->volume == ve->volumeId[BACKVOL])) {
1157 /* backup always is on the same volume as parent */
1159 type |= (VRO | VBackup);
1161 mask = 0; /* Can't find volume in vldb entry */
1164 cellp = afs_GetCell(acell, 0);
1166 /* Gather the list of servers the VLDB says the volume is on
1167 * and initialize the ve->serverHost[] array. If a server struct
1168 * is not found, then get the list of addresses for the
1169 * server, VL_GetAddrsU(), and create a server struct, afs_GetServer().
1171 for (i = 0, j = 0; i < ve->nServers; i++) {
1172 if (((ve->serverFlags[i] & mask) == 0)
1173 || (ve->serverFlags[i] & VLSF_DONTUSE)) {
1174 continue; /* wrong volume don't use this volume */
1177 if (!(ve->serverFlags[i] & VLSF_UUID)) {
1178 /* The server has no uuid */
1179 serverid = htonl(ve->serverNumber[i].time_low);
1180 ts = afs_GetServer(&serverid, 1, acell, cellp->fsport,
1181 WRITE_LOCK, (afsUUID *) 0, 0, av);
1183 ts = afs_FindServer(0, cellp->fsport, &ve->serverNumber[i], 0);
1184 if (ts && (ts->sr_addr_uniquifier == ve->serverUnique[i])
1186 /* uuid, uniquifier, and portal are the same */
1188 afs_uint32 *addrp, code;
1189 afs_int32 nentries, unique;
1191 ListAddrByAttributes attrs;
1193 struct rx_connection *rxconn;
1195 memset(&attrs, 0, sizeof(attrs));
1196 attrs.Mask = VLADDR_UUID;
1197 attrs.uuid = ve->serverNumber[i];
1198 memset(&uuid, 0, sizeof(uuid));
1199 memset(&addrs, 0, sizeof(addrs));
1202 afs_ConnByMHosts(tcell->cellHosts, tcell->vlport,
1203 tcell->cellNum, areq, SHARED_LOCK,
1208 VL_GetAddrsU(rxconn, &attrs, &uuid, &unique,
1215 /* Handle corrupt VLDB (defect 7393) */
1216 if (code == 0 && nentries == 0)
1219 } while (afs_Analyze
1220 (tconn, rxconn, code, NULL, areq, -1, SHARED_LOCK, tcell));
1222 /* Better handing of such failures; for now we'll simply retry this call */
1223 areq->volumeError = 1;
1227 addrp = addrs.bulkaddrs_val;
1228 for (k = 0; k < nentries; k++) {
1229 addrp[k] = htonl(addrp[k]);
1231 ts = afs_GetServer(addrp, nentries, acell,
1232 cellp->fsport, WRITE_LOCK,
1233 &ve->serverNumber[i],
1234 ve->serverUnique[i], av);
1235 xdr_free((xdrproc_t) xdr_bulkaddrs, &addrs);
1240 /* The cell field could be 0 if the server entry was created
1241 * first with the 'fs setserverprefs' call which doesn't set
1242 * the cell field. Thus if the afs_GetServer call above
1243 * follows later on it will find the server entry thus it will
1244 * simply return without setting any fields, so we set the
1245 * field ourselves below.
1249 afs_PutServer(ts, WRITE_LOCK);
1253 ObtainWriteLock(&av->lock, 111);
1255 memcpy(av->serverHost, serverHost, sizeof(serverHost));
1260 /* fill in volume types */
1261 av->rwVol = ((ve->flags & VLF_RWEXISTS) ? ve->volumeId[RWVOL] : 0);
1262 av->roVol = ((ve->flags & VLF_ROEXISTS) ? ve->volumeId[ROVOL] : 0);
1263 av->backVol = ((ve->flags & VLF_BACKEXISTS) ? ve->volumeId[BACKVOL] : 0);
1265 if (ve->flags & VLF_DFSFILESET)
1266 av->states |= VForeign;
1268 afs_SortServers(av->serverHost, AFS_MAXHOSTS);
1269 } /*InstallVolumeEntry */
1273 * Reset volume info for the specified volume strecture. Mark volume
1274 * to be rechecked next time.
1278 afs_ResetVolumeInfo(struct volume *tv)
1282 AFS_STATCNT(afs_ResetVolumeInfo);
1283 ObtainWriteLock(&tv->lock, 117);
1284 tv->states |= VRecheck;
1286 /* the hard-mount code in afs_Analyze may not be able to reset this flag
1287 * when VRecheck is set, so clear it here to ensure it gets cleared. */
1288 tv->states &= ~VHardMount;
1290 for (i = 0; i < AFS_MAXHOSTS; i++)
1291 tv->status[i] = not_busy;
1293 afs_osi_Free(tv->name, strlen(tv->name) + 1);
1296 ReleaseWriteLock(&tv->lock);