jimzah/openafs
1
0
Fork 0
mirror of https://git.openafs.org/openafs.git synced 2025-01-18 23:10:58 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Refactor afs_NewVCache

Browse Source 
afs_NewVCache was a twisty turny maze of #ifdefs and duplicated code.
This makes a number of sweeping changes to simplify this code, and to
move platform specific elements out into their own directories.

*) ShakeLooseVCaches is refactored so that the same code can be used
   both for platforms that support dynamic vcaches, and those which
   don't.
*) afs_NewVCache, ShakeLooseVCaches, and afs_AllocVCache are all
   modified to remove platform specific code, and to call platform
   specific functions.
*) A new platform file 'osi_vcache.c' is created to hold a number of
   platform specific vcache operations:
   *) osi_TryEvictVCache handles the decision of whether a vcache can
      be evicted or not, and does so if required
   *) osi_NewVnode allocates a new vnode
   *) osi_PrePopulateVCache does the necessary population of the
      vcache, before it's threaded onto the VLRUQ and associated hash
      tables.
   *) osi_AttachVnode handles attaching an OS vnode to our vcache,
      where that is necessary
   *) osi_PostPopulateVCache handles the vcache population that must
      occur after we're on the VLRUQ and have a vnode attached.

Change-Id: I368e5fb500d012b44141aa8f8cf0516e63e58f57
Reviewed-on: http://gerrit.openafs.org/1881
Reviewed-by: Derrick Brashear <shadow@dementia.org>
Tested-by: Derrick Brashear <shadow@dementia.org>
This commit is contained in:
Simon Wilkinson 2009-11-07 00:16:28 +00:00 committed by Derrick Brashear
parent 5e09bcd936
commit 9be76c0d31
26 changed files with 1086 additions and 468 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

75
src/afs/AIX/osi_vcache.c Normal file
View File

@ -0,0 +1,75 @@
/*
* Copyright 2000, International Business Machines Corporation and others.
* All Rights Reserved.
*
* This software has been released under the terms of the IBM Public
* License. For details, see the LICENSE file in the top-level source
* directory or online at http://www.openafs.org/dl/license10.html
*/
#include <afsconfig.h>
#include "afs/param.h"
#include "afs/sysincludes.h" /*Standard vendor system headers */
#include "afsincludes.h" /*AFS-based standard headers */
extern struct vnodeops *afs_ops;
int
osi_TryEvictVCache(struct vcache *avc, int *slept) {
if (!VREFCOUNT_GT(avc,0)
&& avc->opens == 0 && (avc->f.states & CUnlinkedDel) == 0) {
code = afs_FlushVCache(avc, slept);
if (code == 0)
return 1;
}
return 0;
}
struct vcache *
osi_NewVnode(void) {
struct vcache *tvc;
tvc = (struct vcache *)afs_osi_Alloc(sizeof(struct vcache));
#ifdef KERNEL_HAVE_PIN
pin((char *)tvc, sizeof(struct vcache)); /* XXX */
#endif
return tvc;
}
void
osi_PrePopulateVCache(struct vcache *avc) {
memset(avc, 0, sizeof(struct vcache));
#ifdef AFS_AIX32_ENV
LOCK_INIT(&avc->pvmlock, "vcache pvmlock");
avc->vmh = avc->segid = NULL;
avc->credp = NULL;
#endif
/* Don't forget to free the gnode space */
avc->v.v_gnode = osi_AllocSmallSpace(sizeof(struct gnode));
memset(avc->v.v_gnode, 0, sizeof(struct gnode));
}
void
osi_AttachVnode(struct vcache *avc, int seq) { }
void
osi_PostPopulateVCache(struct vcache *avc) {
avc->v.v_op = afs_ops;
avc->v.v_vfsp = afs_globalVFS;
avc->v.v_type = VREG;
avc->v.v_vfsnext = afs_globalVFS->vfs_vnodes; /* link off vfs */
avc->v.v_vfsprev = NULL;
afs_globalVFS->vfs_vnodes = &avc->v;
if (avc->v.v_vfsnext != NULL)
avc->v.v_vfsnext->v_vfsprev = &avc->v;
avc->v.v_next = avc->v.v_gnode->gn_vnode; /*Single vnode per gnode for us! */
avc->v.v_gnode->gn_vnode = &avc->v;
}

117
src/afs/DARWIN/osi_vcache.c Normal file
View File

@ -0,0 +1,117 @@
/*
* Copyright 2000, International Business Machines Corporation and others.
* All Rights Reserved.
*
* This software has been released under the terms of the IBM Public
* License. For details, see the LICENSE file in the top-level source
* directory or online at http://www.openafs.org/dl/license10.html
*/
#include <afsconfig.h>
#include "afs/param.h"
#include "afs/sysincludes.h" /*Standard vendor system headers */
#include "afsincludes.h" /*AFS-based standard headers */
struct vcache *
osi_NewVnode(void) {
struct vcache *tvc;
tvc = (struct vcache *)afs_osi_Alloc(sizeof(struct vcache));
tvc->v = NULL; /* important to clean this, or use memset 0 */
return tvc;
}
#if defined(AFS_DARWIN80_ENV)
int
osi_TryEvictVCache(struct vcache *avc, int *slept) {
*slept = 0;
if (!VREFCOUNT_GT(avc, 0) && avc->opens == 0 &&
(avc->f.states & CUnlinkedDel) == 0) {
vnode_t tvp = AFSTOV(avc);
/* VREFCOUNT_GT only sees usecounts, not iocounts */
/* so this may fail to actually recycle the vnode now */
/* must call vnode_get to avoid races. */
if (vnode_get(tvp) == 0) {
*slept=1;
/* must release lock, since vnode_put will immediately
reclaim if there are no other users */
ReleaseWriteLock(&afs_xvcache);
AFS_GUNLOCK();
vnode_recycle(tvp);
vnode_put(tvp);
AFS_GLOCK();
ObtainWriteLock(&afs_xvcache, 336);
}
/* we can't use the vnode_recycle return value to figure
* this out, since the iocount we have to hold makes it
* always "fail" */
if (AFSTOV(avc) == tvp) {
if (*slept) {
QRemove(&avc->vlruq);
QAdd(&VLRU, &avc->vlruq);
}
return 0;
} else
return 1;
}
return 0;
}
#else
int
osi_TryEvictVCache(struct vcache *avc, int *slept) {
if (!VREFCOUNT_GT(avc,0)
|| ((VREFCOUNT(avc) == 1) && (UBCINFOEXISTS(AFSTOV(avc))))
&& avc->opens == 0 && (avc->f.states & CUnlinkedDel) == 0)
{
/*
* vgone() reclaims the vnode, which calls afs_FlushVCache(),
* then it puts the vnode on the free list.
* If we don't do this we end up with a cleaned vnode that's
* not on the free list.
*/
AFS_GUNLOCK();
vgone(AFSTOV(avc));
AFS_GLOCK();
return 1;
}
return 0;
}
#endif /* AFS_DARWIN80_ENV */
void
osi_PrePopulateVCache(struct vcache *avc) {
memset(avc, 0, sizeof(struct vcache));
/* PPC Darwin 80 seems to be a BOZONLOCK environment, so we need this
* here ... */
#if defined(AFS_BOZONLOCK_ENV)
afs_BozonInit(&avc->pvnLock, avc);
#endif
}
void
osi_AttachVnode(struct vcache *avc, int seq) {
ReleaseWriteLock(&afs_xvcache);
AFS_GUNLOCK();
afs_darwin_getnewvnode(avc, seq ? 0 : 1); /* includes one refcount */
AFS_GLOCK();
ObtainWriteLock(&afs_xvcache,338);
#ifdef AFS_DARWIN80_ENV
LOCKINIT(avc->rwlock);
#else
lockinit(&avc->rwlock, PINOD, "vcache", 0, 0);
#endif
}
void
osi_PostPopulateVCache(struct vcache *avc) {
#if !defined(AFS_DARWIN80_ENV)
avc->v->v_mount = afs_globalVFS;
#endif
vSetType(avc, VREG);
}

112
src/afs/FBSD/osi_vcache.c Normal file
View File

@ -0,0 +1,112 @@
/*
* Copyright 2000, International Business Machines Corporation and others.
* All Rights Reserved.
*
* This software has been released under the terms of the IBM Public
* License. For details, see the LICENSE file in the top-level source
* directory or online at http://www.openafs.org/dl/license10.html
*/
#include <afsconfig.h>
#include "afs/param.h"
#include "afs/sysincludes.h" /*Standard vendor system headers */
#include "afsincludes.h" /*AFS-based standard headers */
int
osi_TryEvictVCache(struct vcache *avc, int *slept) {
if (!VREFCOUNT_GT(avc,0)
&& avc->opens == 0 && (avc->f.states & CUnlinkedDel) == 0) {
/*
* vgone() reclaims the vnode, which calls afs_FlushVCache(),
* then it puts the vnode on the free list.
* If we don't do this we end up with a cleaned vnode that's
* not on the free list.
* XXX assume FreeBSD is the same for now.
*/
AFS_GUNLOCK();
#if defined(AFS_FBSD80_ENV)
/* vgone() is correct, but v_usecount is assumed not
* to be 0, and I suspect that currently our usage ensures that
* in fact it will */
if (vrefcnt(AFSTOV(tvc)) < 1) {
vref(AFSTOV(tvc));
}
vn_lock(AFSTOV(tvc), LK_EXCLUSIVE | LK_RETRY); /* !glocked */
#endif
vgone(AFSTOV(avc));
#if defined(AFS_FBSD80_ENV)
VOP_UNLOCK(AFSTOV(tvc), 0);
#endif
AFS_GLOCK();
return 1;
}
return 0;
}
struct vcache *
osi_NewVnode(void) {
struct vcache *tvc;
tvc = (struct vcache *)afs_osi_Alloc(sizeof(struct vcache));
tvc->v = NULL; /* important to clean this, or use memset 0 */
return tvc;
}
void
osi_PrePopulateVCache(struct vcache *avc) {
memset(avc, 0, sizeof(struct vcache));
}
void
osi_AttachVnode(struct vcache *avc, int seq) {
struct vnode *vp;
ReleaseWriteLock(&afs_xvcache);
AFS_GUNLOCK();
#if defined(AFS_FBSD60_ENV)
if (getnewvnode(MOUNT_AFS, afs_globalVFS, &afs_vnodeops, &vp))
#elif defined(AFS_FBSD50_ENV)
if (getnewvnode(MOUNT_AFS, afs_globalVFS, afs_vnodeop_p, &vp))
#else
if (getnewvnode(VT_AFS, afs_globalVFS, afs_vnodeop_p, &vp))
#endif
panic("afs getnewvnode"); /* can't happen */
#ifdef AFS_FBSD70_ENV
/* XXX verified on 80--TODO check on 7x */
if (!vp->v_mount) {
vn_lock(vp, LK_EXCLUSIVE | LK_RETRY); /* !glocked */
insmntque(vp, afs_globalVFS);
VOP_UNLOCK(vp, 0);
}
#endif
AFS_GLOCK();
ObtainWriteLock(&afs_xvcache,339);
if (avc->v != NULL) {
/* I'd like to know if this ever happens...
* We don't drop global for the rest of this function,
* so if we do lose the race, the other thread should
* have found the same vnode and finished initializing
* the vcache entry. Is it conceivable that this vcache
* entry could be recycled during this interval? If so,
* then there probably needs to be some sort of additional
* mutual exclusion (an Embryonic flag would suffice).
* -GAW */
afs_warn("afs_NewVCache: lost the race\n");
return (avc);
}
avc->v = vp;
avc->v->v_data = avc;
lockinit(&avc->rwlock, PINOD, "vcache", 0, 0);
}
void
osi_PostPopulateVCache(struct vcache *avc) {
avc->v->v_mount = afs_globalVFS;
vSetType(avc, VREG);
}

51
src/afs/HPUX/osi_vcache.c Normal file
View File

@ -0,0 +1,51 @@
/*
* Copyright 2000, International Business Machines Corporation and others.
* All Rights Reserved.
*
* This software has been released under the terms of the IBM Public
* License. For details, see the LICENSE file in the top-level source
* directory or online at http://www.openafs.org/dl/license10.html
*/
#include <afsconfig.h>
#include "afs/param.h"
#include "afs/sysincludes.h" /*Standard vendor system headers */
#include "afsincludes.h" /*AFS-based standard headers */
int
osi_TryEvictVCache(struct vcache *avc, int *slept) {
int code;
if (!VREFCOUNT_GT(avc,0)
&& avc->opens == 0 && (avc->f.states & CUnlinkedDel) == 0) {
code = afs_FlushVCache(avc, slept);
if (code == 0)
return 1;
}
return 0;
}
struct vcache *
osi_NewVnode(void) {
return afs_osi_Alloc(sizeof(struct vcache));
}
void
osi_PrePopulateVCache(struct vcache *avc) {
memset(avc, 0, sizeof(struct vcache));
avc->flushDV.low = avc->flushDV.high = AFS_MAXDV;
}
void
osi_AttachVnode(struct vcache *avc, int seq) {
}
void
osi_PostPopulateVCache(struct vcache *avc) {
AFSTOV(avc)->v_op = afs_ops;
AFSTOV(avc)->v_mount = afs_globalVFS;
vSetType(avc, VREG);
}

112
src/afs/IRIX/osi_vcache.c Normal file
View File

@ -0,0 +1,112 @@
/*
* Copyright 2000, International Business Machines Corporation and others.
* All Rights Reserved.
*
* This software has been released under the terms of the IBM Public
* License. For details, see the LICENSE file in the top-level source
* directory or online at http://www.openafs.org/dl/license10.html
*/
#include <afsconfig.h>
#include "afs/param.h"
#include "afs/sysincludes.h" /*Standard vendor system headers */
#include "afsincludes.h" /*AFS-based standard headers */
int
osi_TryEvictVCache(struct vcache *avc, int *slept) {
if (!VREFCOUNT_GT(avc,0)
&& avc->opens == 0 && (avc->f.states & CUnlinkedDel) == 0) {
code = afs_FlushVCache(avc, slept);
if (code == 0)
return 1;
}
return 0;
}
struct vcache *
osi_NewVnode(void) {
struct vcache *avc;
char name[METER_NAMSZ];
avc = afs_osi_Alloc(sizeof(struct vcache));
memset(avc, 0, sizeof(struct vcache));
avc->v.v_number = ++afsvnumbers;
avc->vc_rwlockid = OSI_NO_LOCKID;
initnsema(&avc->vc_rwlock, 1,
makesname(name, "vrw", avc->v.v_number));
#ifndef AFS_SGI53_ENV
initnsema(&avc->v.v_sync, 0,
makesname(name, "vsy", avc->v.v_number));
#endif
#ifndef AFS_SGI62_ENV
initnlock(&avc->v.v_lock,
makesname(name, "vlk", avc->v.v_number));
#endif
return avc;
}
void
osi_PrePopulateVCache(struct vcache *avc) {
avc->uncred = 0;
memset(&(avc->f), 0, sizeof(struct fvcache));
}
void
osi_AttachVnode(struct vcache *avc, int seq) { }
void
osi_PostPopulateVCache(struct vcache *avc) {
memset(&(avc->vc_bhv_desc), 0, sizeof(avc->vc_bhv_desc));
bhv_desc_init(&(avc->vc_bhv_desc), avc, avc, &Afs_vnodeops);
#if defined(AFS_SGI65_ENV)
vn_bhv_head_init(&(avc->v.v_bh), "afsvp");
vn_bhv_insert_initial(&(avc->v.v_bh), &(avc->vc_bhv_desc));
avc->v.v_mreg = avc->v.v_mregb = (struct pregion *)avc;
# if defined(VNODE_TRACING)
avc->v.v_trace = ktrace_alloc(VNODE_TRACE_SIZE, 0);
# endif
init_bitlock(&avc->v.v_pcacheflag, VNODE_PCACHE_LOCKBIT, "afs_pcache",
avc->v.v_number);
init_mutex(&avc->v.v_filocksem, MUTEX_DEFAULT, "afsvfl", (long)avc);
init_mutex(&avc->v.v_buf_lock, MUTEX_DEFAULT, "afsvnbuf", (long)avc);
#else
bhv_head_init(&(avc->v.v_bh));
bhv_insert_initial(&(avc->v.v_bh), &(avc->vc_bhv_desc));
#endif
vnode_pcache_init(&avc->v);
#if defined(DEBUG) && defined(VNODE_INIT_BITLOCK)
/* Above define is never true execpt in SGI test kernels. */
init_bitlock(&avc->v.v_flag, VLOCK, "vnode", avc->v.v_number);
#endif
#ifdef INTR_KTHREADS
AFS_VN_INIT_BUF_LOCK(&(avc->v));
#endif
avc->v.v_type = afs_globalVFS;
vSetType(avc, VREG);
VN_SET_DPAGES(&(avc->v), (struct pfdat *)NULL);
osi_Assert((avc->v.v_flag & VINACT) == 0);
avc->v.v_flag = 0;
osi_Assert(VN_GET_PGCNT(&(avc->v)) == 0);
osi_Assert(avc->mapcnt == 0 && avc->vc_locktrips == 0);
osi_Assert(avc->vc_rwlockid == OSI_NO_LOCKID);
osi_Assert(avc->v.v_filocks == NULL);
# if !defined(AFS_SGI65_ENV)
osi_Assert(avc->v.v_filocksem == NULL);
# endif
osi_Assert(avc->cred == NULL);
# if defined(AFS_SGI64_ENV)
vnode_pcache_reinit(&avc->v);
avc->v.v_rdev = NODEV;
# endif
vn_initlist((struct vnlist *)&avc->v);
avc->lastr = 0;
}

102
src/afs/LINUX/osi_vcache.c Normal file
View File

@ -0,0 +1,102 @@
/*
* Copyright 2000, International Business Machines Corporation and others.
* All Rights Reserved.
*
* This software has been released under the terms of the IBM Public
* License. For details, see the LICENSE file in the top-level source
* directory or online at http://www.openafs.org/dl/license10.html
*/
#include <afsconfig.h>
#include "afs/param.h"
#include "afs/sysincludes.h" /*Standard vendor system headers */
#include "afsincludes.h" /*AFS-based standard headers */
int
osi_TryEvictVCache(struct vcache *avc, int *slept) {
int code;
struct dentry *dentry;
struct list_head *cur, *head;
/* First, see if we can evict the inode from the dcache */
if (avc != afs_globalVp && VREFCOUNT(avc) > 1 && avc->opens == 0) {
AFS_GUNLOCK();
spin_lock(&dcache_lock);
head = &(AFSTOV(avc))->i_dentry;
restart:
cur = head;
while ((cur = cur->next) != head) {
dentry = list_entry(cur, struct dentry, d_alias);
if (d_unhashed(dentry))
continue;
dget_locked(dentry);
spin_unlock(&dcache_lock);
if (d_invalidate(dentry) == -EBUSY) {
dput(dentry);
/* perhaps lock and try to continue? (use cur as head?) */
goto inuse;
}
dput(dentry);
spin_lock(&dcache_lock);
goto restart;
}
spin_unlock(&dcache_lock);
inuse:
AFS_GLOCK();
}
/* See if we can evict it from the VLRUQ */
if (VREFCOUNT_GT(avc,0) && !VREFCOUNT_GT(avc,1) && avc->opens == 0
&& (avc->f.states & CUnlinkedDel) == 0) {
code = afs_FlushVCache(avc, slept);
if (code == 0)
return 1;
}
return 0;
}
struct vcache *
osi_NewVnode(void)
{
struct inode *ip;
struct vcache *tvc;
AFS_GUNLOCK();
ip = new_inode(afs_globalVFS);
if (!ip)
osi_Panic("afs_NewVCache: no more inodes");
AFS_GLOCK();
#if defined(STRUCT_SUPER_OPERATIONS_HAS_ALLOC_INODE)
tvc = VTOAFS(ip);
#else
tvc = afs_osi_Alloc(sizeof(struct vcache));
ip->u.generic_ip = tvc;
tvc->v = ip;
#endif
return tvc;
}
void
osi_PrePopulateVCache(struct vcache *avc) {
avc->uncred = 0;
memset(&(avc->f), 0, sizeof(struct fvcache));
avc->cred = NULL;
}
void
osi_AttachVnode(struct vcache *avc, int seq) { /* Nada */ }
void
osi_PostPopulateVCache(struct vcache *avc) {
vSetType(avc, VREG);
}

112
src/afs/LINUX24/osi_vcache.c Normal file
View File

@ -0,0 +1,112 @@
/*
* Copyright 2000, International Business Machines Corporation and others.
* All Rights Reserved.
*
* This software has been released under the terms of the IBM Public
* License. For details, see the LICENSE file in the top-level source
* directory or online at http://www.openafs.org/dl/license10.html
*/
#include <afsconfig.h>
#include "afs/param.h"
#include "afs/sysincludes.h" /*Standard vendor system headers */
#include "afsincludes.h" /*AFS-based standard headers */
#if defined(AFS_LINUX24_ENV)
# define afs_linux_lock_dcache() spin_lock(&dcache_lock)
# define afs_linux_unlock_dcache() spin_unlock(&dcache_lock)
#else
# define afs_linux_lock_dcache()
# define afs_linux_unlock_dcache()
#endif
int
osi_TryEvictVCache(struct vcache *avc, int *slept) {
int code;
struct dentry *dentry;
struct list_head *cur, *head;
/* First, see if we can evict the inode from the dcache */
if (avc != afs_globalVp && VREFCOUNT(avc) > 1 && avc->opens == 0) {
AFS_GUNLOCK();
afs_linux_lock_dcache();
head = &(AFSTOV(avc))->i_dentry;
restart:
cur = head;
while ((cur = cur->next) != head) {
dentry = list_entry(cur, struct dentry, d_alias);
if (d_unhashed(dentry))
continue;
dget_locked(dentry);
afs_linux_unlock_dcache();
if (d_invalidate(dentry) == -EBUSY) {
dput(dentry);
/* perhaps lock and try to continue? (use cur as head?) */
goto inuse;
}
dput(dentry);
afs_linux_lock_dcache();
goto restart;
}
afs_linux_unlock_dcache();
inuse:
AFS_GLOCK();
}
/* See if we can evict it from the VLRUQ */
if (VREFCOUNT_GT(avc,0) && !VREFCOUNT_GT(avc,1) && avc->opens == 0
&& (avc->f.states & CUnlinkedDel) == 0) {
code = afs_FlushVCache(avc, slept);
if (code == 0)
return 1;
}
return 0;
}
struct vcache *
osi_NewVnode(void)
{
struct inode *ip;
struct vcache *tvc;
AFS_GUNLOCK();
ip = new_inode(afs_globalVFS);
if (!ip)
osi_Panic("afs_NewVCache: no more inodes");
AFS_GLOCK();
#if defined(STRUCT_SUPER_OPERATIONS_HAS_ALLOC_INODE)
tvc = VTOAFS(ip);
#else
tvc = afs_osi_Alloc(sizeof(struct vcache));
ip->u.generic_ip = tvc;
tvc->v = ip;
#endif
return tvc;
}
/* XXX - This should probably be inline */
void
osi_PrePopulateVCache(struct vcache *avc) {
avc->uncred = 0;
memset(&(avc->f), 0, sizeof(struct fvcache));
}
/* XXX - This should become inline, or a #define */
void
osi_AttachVnode(struct vcache *avc, int seq) { }
/* XXX - Again, inline or a #define */
void
osi_PostPopulateVCache(struct vcache *avc) {
vSetType(avc, VREG);
}

66
src/afs/NBSD/osi_vcache.c Normal file
View File

@ -0,0 +1,66 @@
/*
* Copyright 2000, International Business Machines Corporation and others.
* All Rights Reserved.
*
* This software has been released under the terms of the IBM Public
* License. For details, see the LICENSE file in the top-level source
* directory or online at http://www.openafs.org/dl/license10.html
*/
#include <afsconfig.h>
#include "afs/param.h"
#include "afs/sysincludes.h" /*Standard vendor system headers */
#include "afsincludes.h" /*AFS-based standard headers */
int
osi_TryEvictVCache(struct vcache *avc, int *slept) {
*slept = 0;
if (!VREFCOUNT_GT(avc,0)
&& avc->opens == 0 && (avc->f.states & CUnlinkedDel) == 0) {
/*
* vgone() reclaims the vnode, which calls afs_FlushVCache(),
* then it puts the vnode on the free list.
* If we don't do this we end up with a cleaned vnode that's
* not on the free list.
*/
AFS_GUNLOCK();
vgone(AFSTOV(avc));
AFS_GLOCK();
return 1;
}
return 0;
}
struct vcache *
osi_NewVnode(void) {
struct vcache *tvc;
tvc = (struct vcache *)afs_osi_Alloc(sizeof(struct vcache));
tvc->v = NULL; /* important to clean this, or use memset 0 */
return tvc;
}
void
osi_PrePopulateVCache(struct vcache *avc) {
memset(avc, 0, sizeof(struct vcache));
}
void
osi_AttachVnode(struct vcache *avc, int seq) {
ReleaseWriteLock(&afs_xvcache);
AFS_GUNLOCK();
afs_obsd_getnewvnode(avc); /* includes one refcount */
AFS_GLOCK();
ObtainWriteLock(&afs_xvcache,337);
lockinit(&avc->rwlock, PINOD, "vcache", 0, 0);
}
void
osi_PostPopulateVCache(struct vcache *avc) {
AFSTOV(avc)->v_mount = afs_globalVFS;
vSetType(vc, VREG);
}

66
src/afs/OBSD/osi_vcache.c Normal file
View File

@ -0,0 +1,66 @@
/*
* Copyright 2000, International Business Machines Corporation and others.
* All Rights Reserved.
*
* This software has been released under the terms of the IBM Public
* License. For details, see the LICENSE file in the top-level source
* directory or online at http://www.openafs.org/dl/license10.html
*/
#include <afsconfig.h>
#include "afs/param.h"
#include "afs/sysincludes.h" /*Standard vendor system headers */
#include "afsincludes.h" /*AFS-based standard headers */
int
osi_TryEvictVCache(struct vcache *avc, int *slept) {
*slept = 0;
if (!VREFCOUNT_GT(avc,0)
&& avc->opens == 0 && (avc->f.states & CUnlinkedDel) == 0) {
/*
* vgone() reclaims the vnode, which calls afs_FlushVCache(),
* then it puts the vnode on the free list.
* If we don't do this we end up with a cleaned vnode that's
* not on the free list.
*/
AFS_GUNLOCK();
vgone(AFSTOV(avc));
AFS_GLOCK();
return 1;
}
return 0;
}
struct vcache *
osi_NewVnode(void) {
struct vcache *tvc;
tvc = (struct vcache *)afs_osi_Alloc(sizeof(struct vcache));
tvc->v = NULL; /* important to clean this, or use memset 0 */
return tvc;
}
void
osi_PrePopulateVCache(struct vcache *avc) {
memset(avc, 0, sizeof(struct vcache));
}
void
osi_AttachVnode(struct vcache *avc, int seq) {
ReleaseWriteLock(&afs_xvcache);
AFS_GUNLOCK();
afs_obsd_getnewvnode(avc); /* includes one refcount */
AFS_GLOCK();
ObtainWriteLock(&afs_xvcache,337);
lockinit(&avc->rwlock, PINOD, "vcache", 0, 0);
}
void
osi_PostPopulateVCache(struct vcache *avc) {
AFSTOV(avc)->v_mount = afs_globalVFS;
vSetType(vc, VREG);
}

70
src/afs/SOLARIS/osi_vcache.c Normal file
View File

@ -0,0 +1,70 @@
/*
* Copyright 2000, International Business Machines Corporation and others.
* All Rights Reserved.
*
* This software has been released under the terms of the IBM Public
* License. For details, see the LICENSE file in the top-level source
* directory or online at http://www.openafs.org/dl/license10.html
*/
#include <afsconfig.h>
#include "afs/param.h"
#include "afs/sysincludes.h" /*Standard vendor system headers */
#include "afsincludes.h" /*AFS-based standard headers */
int
osi_TryEvictVCache(struct vcache *avc, int *slept) {
int code;
if (!VREFCOUNT_GT(avc,0)
&& avc->opens == 0 && (avc->f.states & CUnlinkedDel) == 0) {
code = afs_FlushVCache(avc, slept);
if (code == 0)
return 1;
}
return 0;
}
struct vcache *
osi_NewVnode(void) {
return (struct vcache *)afs_osi_Alloc(sizeof(struct vcache));
}
void
osi_PrePopulateVCache(struct vcache *avc) {
memset(avc, 0, sizeof(struct vcache));
AFS_RWLOCK_INIT(&avc->vlock, "vcache vlock");
rw_init(&avc->rwlock, "vcache rwlock", RW_DEFAULT, NULL);
#if defined(AFS_SUN55_ENV)
/* This is required if the kaio (kernel aynchronous io)
** module is installed. Inside the kernel, the function
** check_vp( common/os/aio.c) checks to see if the kernel has
** to provide asynchronous io for this vnode. This
** function extracts the device number by following the
** v_data field of the vnode. If we do not set this field
** then the system panics. The value of the v_data field
** is not really important for AFS vnodes because the kernel
** does not do asynchronous io for regular files. Hence,
** for the time being, we fill up the v_data field with the
** vnode pointer itself. */
avc->v.v_data = (char *)avc;
#endif /* AFS_SUN55_ENV */
#if defined(AFS_BOZONLOCK_ENV)
afs_BozonInit(&avc->pvnLock, avc);
#endif
}
void
osi_AttachVnode(struct vcache *avc, int seq) { }
void
osi_PostPopulateVCache(struct vcache *avc) {
AFSTOV(avc)->v_op = afs_ops;
AFSTOV(avc)->v_vfsp = afs_globalVFS;
vSetType(avc, VREG);
}

49
src/afs/UKERNEL/osi_vcache.c Normal file
View File

@ -0,0 +1,49 @@
/*
* Copyright 2000, International Business Machines Corporation and others.
* All Rights Reserved.
*
* This software has been released under the terms of the IBM Public
* License. For details, see the LICENSE file in the top-level source
* directory or online at http://www.openafs.org/dl/license10.html
*/
#include <afsconfig.h>
#include "afs/param.h"
#include "afs/sysincludes.h" /*Standard vendor system headers */
#include "afsincludes.h" /*AFS-based standard headers */
int
osi_TryEvictVCache(struct vcache *avc, int *slept) {
int code;
if (!VREFCOUNT_GT(avc,0)
&& avc->opens == 0 && (avc->f.states & CUnlinkedDel) == 0) {
code = afs_FlushVCache(avc, slept);
if (code == 0)
return 1;
}
return 0;
}
struct vcache *
osi_NewVnode(void) {
return afs_osi_Alloc(sizeof(struct vcache));
}
void
osi_PrePopulateVCache(struct vcache *avc) {
memset(avc, 0, sizeof(struct vcache));
}
void
osi_AttachVnode(struct vcache *avc, int seq) { }
extern struct vnodeops *afs_ops;
void
osi_PostPopulateVCache(struct vcache *avc) {
AFSTOV(avc)->v_vfsp = afs_globalVFS;
AFSTOV(avc)->v_op = afs_ops;
vSetType(avc, VREG);
}

7
src/afs/afs_osi.h
View File

@ -138,6 +138,13 @@ extern struct vnodeops *afs_ops;
# define SetAfsVnode(v) (v)->v_op = afs_ops # define SetAfsVnode(v) (v)->v_op = afs_ops
#endif #endif
struct vcache;
extern int osi_TryEvictVCache(struct vcache *, int *);
extern struct vcache *osi_NewVnode(void);
extern void osi_PrePopulateVCache(struct vcache *);
extern void osi_PostPopulateVCache(struct vcache *);
extern void osi_AttachVnode(struct vcache *, int seq);
/* /*
* In IRIX 6.5 we cannot have DEBUG turned on since certain * In IRIX 6.5 we cannot have DEBUG turned on since certain
* system-defined structures are a different size with DEBUG on, the * system-defined structures are a different size with DEBUG on, the

592
src/afs/afs_vcache.c
View File

@ -40,9 +40,8 @@
#include <afsconfig.h> #include <afsconfig.h>
#include "afs/param.h" #include "afs/param.h"
#include "afs/sysincludes.h" /*Standard vendor system headers */
#include "afs/sysincludes.h" /*Standard vendor system headers */ #include "afsincludes.h" /*AFS-based standard headers */
#include "afsincludes.h" /*AFS-based standard headers */
#include "afs/afs_stats.h" #include "afs/afs_stats.h"
#include "afs/afs_cbqueue.h" #include "afs/afs_cbqueue.h"
#include "afs/afs_osidnlc.h" #include "afs/afs_osidnlc.h"
@ -230,6 +229,7 @@ afs_FlushVCache(struct vcache *avc, int *slept)
else else
afs_evenZaps++; afs_evenZaps++;
afs_vcount--;
#if !defined(AFS_LINUX22_ENV) #if !defined(AFS_LINUX22_ENV)
/* put the entry in the free list */ /* put the entry in the free list */
avc->nextfree = freeVCList; avc->nextfree = freeVCList;
@ -240,7 +240,6 @@ afs_FlushVCache(struct vcache *avc, int *slept)
avc->f.states |= CVFlushed; avc->f.states |= CVFlushed;
#else #else
/* This should put it back on the vnode free list since usecount is 1 */ /* This should put it back on the vnode free list since usecount is 1 */
afs_vcount--;
vSetType(avc, VREG); vSetType(avc, VREG);
if (VREFCOUNT_GT(avc,0)) { if (VREFCOUNT_GT(avc,0)) {
AFS_RELE(AFSTOV(avc)); AFS_RELE(AFSTOV(avc));
@ -612,98 +611,75 @@ afs_FlushReclaimedVcaches(void)
#endif #endif
} }
void
afs_PostPopulateVCache(struct vcache *avc, struct VenusFid *afid, int seq)
{
/*
* The proper value for mvstat (for root fids) is setup by the caller.
*/
avc->mvstat = 0;
if (afid->Fid.Vnode == 1 && afid->Fid.Unique == 1)
avc->mvstat = 2;
if (afs_globalVFS == 0)
osi_Panic("afs globalvfs");
osi_PostPopulateVCache(avc);
avc->dchint = NULL;
osi_dnlc_purgedp(avc); /* this may be overkill */
memset(&(avc->callsort), 0, sizeof(struct afs_q));
avc->slocks = NULL;
avc->f.states &=~ CVInit;
if (seq) {
avc->f.states |= CBulkFetching;
avc->f.m.Length = seq;
}
afs_osi_Wakeup(&avc->f.states);
}
int int
afs_ShakeLooseVCaches(afs_int32 anumber) afs_ShakeLooseVCaches(afs_int32 anumber)
{ {
#if defined(AFS_LINUX22_ENV) afs_int32 i, loop;
afs_int32 i;
struct vcache *tvc; struct vcache *tvc;
struct afs_q *tq, *uq; struct afs_q *tq, *uq;
int code, fv_slept; int fv_slept;
afs_int32 target = anumber; afs_int32 target = anumber;
if (afsd_dynamic_vcaches || afs_vcount >= afs_maxvcount) { i = 0;
i = 0; loop = 0;
for (tq = VLRU.prev; tq != &VLRU && anumber > 0; tq = uq) { for (tq = VLRU.prev; tq != &VLRU && anumber > 0; tq = uq) {
tvc = QTOV(tq); tvc = QTOV(tq);
uq = QPrev(tq); uq = QPrev(tq);
if (tvc->f.states & CVFlushed) { if (tvc->f.states & CVFlushed) {
refpanic("CVFlushed on VLRU"); refpanic("CVFlushed on VLRU");
} else if (!afsd_dynamic_vcaches && i++ > afs_maxvcount) { /* In the other path, this was 2 * afs_cacheStats */
refpanic("Exceeded pool of AFS vnodes(VLRU cycle?)"); } else if (!afsd_dynamic_vcaches && i++ > afs_maxvcount) {
} else if (QNext(uq) != tq) { refpanic("Exceeded pool of AFS vnodes(VLRU cycle?)");
refpanic("VLRU inconsistent"); } else if (QNext(uq) != tq) {
} else if (!VREFCOUNT_GT(tvc,0)) { refpanic("VLRU inconsistent");
refpanic("refcnt 0 on VLRU"); }
}
#if defined(AFS_LINUX22_ENV) fv_slept = 0;
if (tvc != afs_globalVp && VREFCOUNT(tvc) > 1 && tvc->opens == 0) { if (osi_TryEvictVCache(tvc, &fv_slept))
struct dentry *dentry; anumber--;
struct list_head *cur, *head;
AFS_GUNLOCK();
#if defined(AFS_LINUX24_ENV)
spin_lock(&dcache_lock);
#endif /* AFS_LINUX24_ENV */
head = &(AFSTOV(tvc))->i_dentry;
restart: if (fv_slept) {
cur = head; if (loop++ > 100)
while ((cur = cur->next) != head) {
dentry = list_entry(cur, struct dentry, d_alias);
if (d_unhashed(dentry))
continue;
dget_locked(dentry);
#if defined(AFS_LINUX24_ENV)
spin_unlock(&dcache_lock);
#endif /* AFS_LINUX24_ENV */
if (d_invalidate(dentry) == -EBUSY) {
dput(dentry);
/* perhaps lock and try to continue? (use cur as head?) */
goto inuse;
}
dput(dentry);
#if defined(AFS_LINUX24_ENV)
spin_lock(&dcache_lock);
#endif /* AFS_LINUX24_ENV */
goto restart;
}
#if defined(AFS_LINUX24_ENV)
spin_unlock(&dcache_lock);
#endif /* AFS_LINUX24_ENV */
inuse:
AFS_GLOCK();
}
#endif /* AFS_LINUX22_ENV */
if (VREFCOUNT_GT(tvc,0) && !VREFCOUNT_GT(tvc,1) &&
tvc->opens == 0
&& (tvc->f.states & CUnlinkedDel) == 0) {
code = afs_FlushVCache(tvc, &fv_slept);
if (code == 0) {
anumber--;
}
if (fv_slept) {
uq = VLRU.prev;
i = 0;
continue; /* start over - may have raced. */
}
}
if (tq == uq)
break; break;
uq = VLRU.prev;
i = 0;
continue; /* start over - may have raced. */
} }
if (!afsd_dynamic_vcaches && anumber == target) { if (tq == uq)
afs_warn("afs_ShakeLooseVCaches: warning none freed, using %d of %d\n", break;
afs_vcount, afs_maxvcount); }
} if (!afsd_dynamic_vcaches && anumber == target) {
} /* finished freeing up space */ afs_warn("afs_ShakeLooseVCaches: warning none freed, using %d of %d\n",
/* afs_vcount, afs_maxvcount);
printf("recycled %d entries\n", target-anumber); }
*/
#endif
return 0; return 0;
} }
@ -713,21 +689,8 @@ static struct vcache *
afs_AllocVCache(void) afs_AllocVCache(void)
{ {
struct vcache *tvc; struct vcache *tvc;
#if defined(AFS_LINUX22_ENV)
struct inode *ip;
AFS_GUNLOCK(); tvc = osi_NewVnode();
ip = new_inode(afs_globalVFS);
if (!ip)
osi_Panic("afs_AllocVCache: no more inodes");
AFS_GLOCK();
#if defined(STRUCT_SUPER_OPERATIONS_HAS_ALLOC_INODE)
tvc = VTOAFS(ip);
#else
tvc = afs_osi_Alloc(sizeof(struct vcache));
ip->u.generic_ip = tvc;
tvc->v = ip;
#endif
afs_vcount++; afs_vcount++;
@ -738,35 +701,7 @@ afs_AllocVCache(void)
} }
afs_stats_cmperf.vcacheXAllocs++; /* count in case we have a leak */ afs_stats_cmperf.vcacheXAllocs++; /* count in case we have a leak */
#else
/* none free, making one is better than a panic */
afs_stats_cmperf.vcacheXAllocs++; /* count in case we have a leak */
tvc = (struct vcache *)afs_osi_Alloc(sizeof(struct vcache));
#if (defined(AFS_DARWIN_ENV) || defined(AFS_XBSD_ENV)) && !defined(UKERNEL)
tvc->v = NULL; /* important to clean this, or use memset 0 */
#endif /* DARWIN || XBSD && !UKERNEL */
#ifdef KERNEL_HAVE_PIN
pin((char *)tvc, sizeof(struct vcache)); /* XXX */
#endif
#if defined(AFS_SGI_ENV)
{
char name[METER_NAMSZ];
memset(tvc, 0, sizeof(struct vcache));
tvc->v.v_number = ++afsvnumbers;
tvc->vc_rwlockid = OSI_NO_LOCKID;
initnsema(&tvc->vc_rwlock, 1,
makesname(name, "vrw", tvc->v.v_number));
#ifndef AFS_SGI53_ENV
initnsema(&tvc->v.v_sync, 0,
makesname(name, "vsy", tvc->v.v_number));
#endif
#ifndef AFS_SGI62_ENV
initnlock(&tvc->v.v_lock,
makesname(name, "vlk", tvc->v.v_number));
#endif
}
#endif /* AFS_SGI_ENV */
#endif
#ifdef AFS_DISCON_ENV #ifdef AFS_DISCON_ENV
/* If we create a new inode, we either give it a new slot number, /* If we create a new inode, we either give it a new slot number,
* or if one's available, use a slot number from the slot free list * or if one's available, use a slot number from the slot free list
@ -786,6 +721,53 @@ afs_AllocVCache(void)
return tvc; return tvc;
} }
/* Pre populate a newly allocated vcache. On platforms where the actual
* vnode is attached to the vcache, this function is called before attachment,
* therefore it cannot perform any actions on the vnode itself */
static void
afs_PrePopulateVCache(struct vcache *avc, struct VenusFid *afid,
struct server *serverp) {
#if defined(AFS_DISCON_ENV)
afs_uint32 slot;
slot = avc->diskSlot;
#endif
osi_PrePopulateVCache(avc);
#if defined(AFS_DISCON_ENV)
avc->diskSlot = slot;
QZero(&avc->metadirty);
#endif
AFS_RWLOCK_INIT(&avc->lock, "vcache lock");
avc->mvid = NULL;
avc->linkData = NULL;
avc->cbExpires = 0;
avc->opens = 0;
avc->execsOrWriters = 0;
avc->flockCount = 0;
avc->f.states = CVInit;
avc->last_looker = 0;
avc->f.fid = *afid;
avc->asynchrony = -1;
avc->vc_error = 0;
hzero(avc->mapDV);
avc->f.truncPos = AFS_NOTRUNC; /* don't truncate until we need to */
hzero(avc->f.m.DataVersion); /* in case we copy it into flushDV */
avc->Access = NULL;
avc->callback = serverp; /* to minimize chance that clear
* request is lost */
#if defined(AFS_CACHE_BYPASS)
avc->cachingStates = 0;
avc->cachingTransitions = 0;
#endif
}
/*! /*!
* This routine is responsible for allocating a new cache entry * This routine is responsible for allocating a new cache entry
* from the free list. It formats the cache entry and inserts it * from the free list. It formats the cache entry and inserts it
@ -806,13 +788,6 @@ afs_NewVCache_int(struct VenusFid *afid, struct server *serverp, int seq)
struct vcache *tvc; struct vcache *tvc;
afs_int32 i, j; afs_int32 i, j;
afs_int32 anumber = VCACHE_FREE; afs_int32 anumber = VCACHE_FREE;
#ifdef AFS_AIX_ENV
struct gnode *gnodepnt;
#endif
#if !defined(AFS_LINUX22_ENV)
struct afs_q *tq, *uq;
int code, fv_slept;
#endif
AFS_STATCNT(afs_NewVCache); AFS_STATCNT(afs_NewVCache);
@ -830,101 +805,8 @@ afs_NewVCache_int(struct VenusFid *afid, struct server *serverp, int seq)
#else /* AFS_LINUX22_ENV */ #else /* AFS_LINUX22_ENV */
/* pull out a free cache entry */ /* pull out a free cache entry */
if (!freeVCList) { if (!freeVCList) {
int loop = 0; afs_ShakeLooseVCaches(anumber);
i = 0; }
for (tq = VLRU.prev; (anumber > 0) && (tq != &VLRU); tq = uq) {
tvc = QTOV(tq);
uq = QPrev(tq);
if (tvc->f.states & CVFlushed) {
refpanic("CVFlushed on VLRU");
} else if (i++ > 2 * afs_cacheStats) { /* even allowing for a few xallocs... */
refpanic("Increase -stat parameter of afsd(VLRU cycle?)");
} else if (QNext(uq) != tq) {
refpanic("VLRU inconsistent");
} else if (tvc->f.states & CVInit) {
continue;
}
if (!VREFCOUNT_GT(tvc,0)
#if defined(AFS_DARWIN_ENV) && !defined(UKERNEL) && !defined(AFS_DARWIN80_ENV)
|| ((VREFCOUNT(tvc) == 1) &&
(UBCINFOEXISTS(AFSTOV(tvc))))
#endif
&& tvc->opens == 0 && (tvc->f.states & CUnlinkedDel) == 0) {
#if defined (AFS_DARWIN_ENV) || defined(AFS_XBSD_ENV)
#ifdef AFS_DARWIN80_ENV
vnode_t tvp = AFSTOV(tvc);
/* VREFCOUNT_GT only sees usecounts, not iocounts */
/* so this may fail to actually recycle the vnode now */
/* must call vnode_get to avoid races. */
fv_slept = 0;
if (vnode_get(tvp) == 0) {
fv_slept=1;
/* must release lock, since vnode_put will immediately
reclaim if there are no other users */
ReleaseWriteLock(&afs_xvcache);
AFS_GUNLOCK();
vnode_recycle(tvp);
vnode_put(tvp);
AFS_GLOCK();
ObtainWriteLock(&afs_xvcache, 336);
}
/* we can't use the vnode_recycle return value to figure
* this out, since the iocount we have to hold makes it
* always "fail" */
if (AFSTOV(tvc) == tvp) {
if (anumber > 0 && fv_slept) {
QRemove(&tvc->vlruq);
QAdd(&VLRU, &tvc->vlruq);
}
code = EBUSY;
} else
code = 0;
#else /* AFS_DARWIN80_ENV */
/*
* vgone() reclaims the vnode, which calls afs_FlushVCache(),
* then it puts the vnode on the free list.
* If we don't do this we end up with a cleaned vnode that's
* not on the free list.
* XXX assume FreeBSD is the same for now.
*/
AFS_GUNLOCK();
#if defined(AFS_FBSD80_ENV)
/* vgone() is correct, but v_usecount is assumed not
* to be 0, and I suspect that currently our usage ensures that
* in fact it will */
if (vrefcnt(AFSTOV(tvc)) < 1) {
vref(AFSTOV(tvc));
}
vn_lock(AFSTOV(tvc), LK_EXCLUSIVE | LK_RETRY); /* !glocked */
#endif
vgone(AFSTOV(tvc));
#if defined(AFS_FBSD80_ENV)
VOP_UNLOCK(AFSTOV(tvc), 0);
#endif
fv_slept = 0;
code = 0;
AFS_GLOCK();
#endif
#else /* AFS_DARWIN80_ENV || AFS_XBSD_ENV */
code = afs_FlushVCache(tvc, &fv_slept);
#endif /* AFS_DARWIN80_ENV || AFS_XBSD_ENV */
if (code == 0) {
anumber--;
}
if (fv_slept) {
if (loop++ > 100)
break;
uq = VLRU.prev;
i = 0;
continue; /* start over - may have raced. */
}
}
if (tq == uq)
break;
}
} /* end of if (!freeVCList) */
if (!freeVCList) { if (!freeVCList) {
tvc = afs_AllocVCache(); tvc = afs_AllocVCache();
@ -941,57 +823,10 @@ afs_NewVCache_int(struct VenusFid *afid, struct server *serverp, int seq)
panic("afs_NewVCache(): free vcache with vnode attached"); panic("afs_NewVCache(): free vcache with vnode attached");
#endif #endif
#if !defined(AFS_SGI_ENV) && !defined(AFS_LINUX22_ENV) /* Populate the vcache with as much as we can. */
afs_PrePopulateVCache(tvc, afid, serverp);
#if defined(AFS_DISCON_ENV) /* Thread the vcache onto the VLRU */
/* We need to preserve the slot that we're being stored into on
* disk */
{
afs_uint32 slot;
slot = tvc->diskSlot;
memset(tvc, 0, sizeof(struct vcache));
tvc->diskSlot = slot;
}
#else
memset(tvc, 0, sizeof(struct vcache));
#endif
#else
tvc->uncred = 0;
memset(&(tvc->f), 0, sizeof(struct fvcache));
#endif
AFS_RWLOCK_INIT(&tvc->lock, "vcache lock");
#if defined(AFS_SUN5_ENV)
AFS_RWLOCK_INIT(&tvc->vlock, "vcache vlock");
#endif /* defined(AFS_SUN5_ENV) */
tvc->mvid = NULL;
tvc->linkData = NULL;
tvc->cbExpires = 0;
tvc->opens = 0;
tvc->execsOrWriters = 0;
tvc->flockCount = 0;
tvc->f.states = CVInit;
tvc->last_looker = 0;
tvc->f.fid = *afid;
tvc->asynchrony = -1;
tvc->vc_error = 0;
#if defined(AFS_LINUX26_ENV)
tvc->cred = NULL;
#endif
#ifdef AFS_TEXT_ENV
tvc->flushDV.low = tvc->flushDV.high = AFS_MAXDV;
#endif
hzero(tvc->mapDV);
tvc->f.truncPos = AFS_NOTRUNC; /* don't truncate until we need to */
hzero(tvc->f.m.DataVersion); /* in case we copy it into flushDV */
tvc->Access = NULL;
tvc->callback = serverp; /* to minimize chance that clear
* request is lost */
#if defined(AFS_DISCON_ENV)
QZero(&tvc->metadirty);
#endif
i = VCHash(afid); i = VCHash(afid);
j = VCHashV(afid); j = VCHashV(afid);
@ -1014,69 +849,14 @@ afs_NewVCache_int(struct VenusFid *afid, struct server *serverp, int seq)
refpanic("NewVCache VLRU inconsistent4"); refpanic("NewVCache VLRU inconsistent4");
} }
vcachegen++; vcachegen++;
/* it should now be safe to drop the xvcache lock */
#if defined(AFS_OBSD_ENV) || defined(AFS_NBSD_ENV)
ReleaseWriteLock(&afs_xvcache);
AFS_GUNLOCK();
afs_obsd_getnewvnode(tvc); /* includes one refcount */
AFS_GLOCK();
ObtainWriteLock(&afs_xvcache,337);
lockinit(&tvc->rwlock, PINOD, "vcache", 0, 0);
#endif
#ifdef AFS_DARWIN_ENV
ReleaseWriteLock(&afs_xvcache);
AFS_GUNLOCK();
afs_darwin_getnewvnode(tvc, seq ? 0 : 1); /* includes one refcount */
AFS_GLOCK();
ObtainWriteLock(&afs_xvcache,338);
#ifdef AFS_DARWIN80_ENV
LOCKINIT(tvc->rwlock);
#else
lockinit(&tvc->rwlock, PINOD, "vcache", 0, 0);
#endif
#endif
#ifdef AFS_FBSD_ENV
{
struct vnode *vp;
ReleaseWriteLock(&afs_xvcache); /* it should now be safe to drop the xvcache lock - so attach an inode
AFS_GUNLOCK(); * to this vcache, where necessary */
#if defined(AFS_FBSD60_ENV) osi_AttachVnode(tvc, seq);
if (getnewvnode(MOUNT_AFS, afs_globalVFS, &afs_vnodeops, &vp))
#elif defined(AFS_FBSD50_ENV) /* Get a reference count to hold this vcache for the VLRUQ. Note that
if (getnewvnode(MOUNT_AFS, afs_globalVFS, afs_vnodeop_p, &vp)) * we have to do this after attaching the vnode, because the reference
#else * count may be held in the vnode itself */
if (getnewvnode(VT_AFS, afs_globalVFS, afs_vnodeop_p, &vp))
#endif
panic("afs getnewvnode"); /* can't happen */
#ifdef AFS_FBSD70_ENV
/* XXX verified on 80--TODO check on 7x */
if (!vp->v_mount) {
vn_lock(vp, LK_EXCLUSIVE | LK_RETRY); /* !glocked */
insmntque(vp, afs_globalVFS);
VOP_UNLOCK(vp, 0);
}
#endif
AFS_GLOCK();
ObtainWriteLock(&afs_xvcache,339);
if (tvc->v != NULL) {
/* I'd like to know if this ever happens...
* We don't drop global for the rest of this function,
* so if we do lose the race, the other thread should
* have found the same vnode and finished initializing
* the vcache entry. Is it conceivable that this vcache
* entry could be recycled during this interval? If so,
* then there probably needs to be some sort of additional
* mutual exclusion (an Embryonic flag would suffice).
* -GAW */
afs_warn("afs_NewVCache: lost the race\n");
return (tvc);
}
tvc->v = vp;
tvc->v->v_data = tvc;
lockinit(&tvc->rwlock, PINOD, "vcache", 0, 0);
}
#endif
#if defined(AFS_LINUX22_ENV) #if defined(AFS_LINUX22_ENV)
/* Hold it for the LRU (should make count 2) */ /* Hold it for the LRU (should make count 2) */
@ -1085,127 +865,7 @@ afs_NewVCache_int(struct VenusFid *afid, struct server *serverp, int seq)
VREFCOUNT_SET(tvc, 1); /* us */ VREFCOUNT_SET(tvc, 1); /* us */
#endif #endif
#ifdef AFS_AIX32_ENV afs_PostPopulateVCache(tvc, afid, seq);
LOCK_INIT(&tvc->pvmlock, "vcache pvmlock");
tvc->vmh = tvc->segid = NULL;
tvc->credp = NULL;
#endif
#if defined(AFS_CACHE_BYPASS)
tvc->cachingStates = 0;
tvc->cachingTransitions = 0;
#endif
#ifdef AFS_BOZONLOCK_ENV
#if defined(AFS_SUN5_ENV)
rw_init(&tvc->rwlock, "vcache rwlock", RW_DEFAULT, NULL);
#if defined(AFS_SUN55_ENV)
/* This is required if the kaio (kernel aynchronous io)
** module is installed. Inside the kernel, the function
** check_vp( common/os/aio.c) checks to see if the kernel has
** to provide asynchronous io for this vnode. This
** function extracts the device number by following the
** v_data field of the vnode. If we do not set this field
** then the system panics. The value of the v_data field
** is not really important for AFS vnodes because the kernel
** does not do asynchronous io for regular files. Hence,
** for the time being, we fill up the v_data field with the
** vnode pointer itself. */
tvc->v.v_data = (char *)tvc;
#endif /* AFS_SUN55_ENV */
#endif
afs_BozonInit(&tvc->pvnLock, tvc);
#endif
/* initialize vnode data, note vrefCount is v.v_count */
#ifdef AFS_AIX_ENV
/* Don't forget to free the gnode space */
tvc->v.v_gnode = gnodepnt =
(struct gnode *)osi_AllocSmallSpace(sizeof(struct gnode));
memset(gnodepnt, 0, sizeof(struct gnode));
#endif
#ifdef AFS_SGI64_ENV
memset((void *)&(tvc->vc_bhv_desc), 0, sizeof(tvc->vc_bhv_desc));
bhv_desc_init(&(tvc->vc_bhv_desc), tvc, tvc, &Afs_vnodeops);
#ifdef AFS_SGI65_ENV
vn_bhv_head_init(&(tvc->v.v_bh), "afsvp");
vn_bhv_insert_initial(&(tvc->v.v_bh), &(tvc->vc_bhv_desc));
#else
bhv_head_init(&(tvc->v.v_bh));
bhv_insert_initial(&(tvc->v.v_bh), &(tvc->vc_bhv_desc));
#endif
#ifdef AFS_SGI65_ENV
tvc->v.v_mreg = tvc->v.v_mregb = (struct pregion *)tvc;
#ifdef VNODE_TRACING
tvc->v.v_trace = ktrace_alloc(VNODE_TRACE_SIZE, 0);
#endif
init_bitlock(&tvc->v.v_pcacheflag, VNODE_PCACHE_LOCKBIT, "afs_pcache",
tvc->v.v_number);
init_mutex(&tvc->v.v_filocksem, MUTEX_DEFAULT, "afsvfl", (long)tvc);
init_mutex(&tvc->v.v_buf_lock, MUTEX_DEFAULT, "afsvnbuf", (long)tvc);
#endif
vnode_pcache_init(&tvc->v);
#if defined(DEBUG) && defined(VNODE_INIT_BITLOCK)
/* Above define is never true except in SGI test kernels. */
init_bitlock(&(tvc->v.v_flag, VLOCK, "vnode", tvc->v.v_number));
#endif
#ifdef INTR_KTHREADS
AFS_VN_INIT_BUF_LOCK(&(tvc->v));
#endif
#else
SetAfsVnode(AFSTOV(tvc));
#endif /* AFS_SGI64_ENV */
/*
* The proper value for mvstat (for root fids) is setup by the caller.
*/
tvc->mvstat = 0;
if (afid->Fid.Vnode == 1 && afid->Fid.Unique == 1)
tvc->mvstat = 2;
if (afs_globalVFS == 0)
osi_Panic("afs globalvfs");
#if !defined(AFS_LINUX22_ENV)
vSetVfsp(tvc, afs_globalVFS);
#endif
vSetType(tvc, VREG);
#ifdef AFS_AIX_ENV
tvc->v.v_vfsnext = afs_globalVFS->vfs_vnodes; /* link off vfs */
tvc->v.v_vfsprev = NULL;
afs_globalVFS->vfs_vnodes = &tvc->v;
if (tvc->v.v_vfsnext != NULL)
tvc->v.v_vfsnext->v_vfsprev = &tvc->v;
tvc->v.v_next = gnodepnt->gn_vnode; /*Single vnode per gnode for us! */
gnodepnt->gn_vnode = &tvc->v;
#endif
#if defined(AFS_SGI_ENV)
VN_SET_DPAGES(&(tvc->v), (struct pfdat *)NULL);
osi_Assert((tvc->v.v_flag & VINACT) == 0);
tvc->v.v_flag = 0;
osi_Assert(VN_GET_PGCNT(&(tvc->v)) == 0);
osi_Assert(tvc->mapcnt == 0 && tvc->vc_locktrips == 0);
osi_Assert(tvc->vc_rwlockid == OSI_NO_LOCKID);
osi_Assert(tvc->v.v_filocks == NULL);
#if !defined(AFS_SGI65_ENV)
osi_Assert(tvc->v.v_filocksem == NULL);
#endif
osi_Assert(tvc->cred == NULL);
#ifdef AFS_SGI64_ENV
vnode_pcache_reinit(&tvc->v);
tvc->v.v_rdev = NODEV;
#endif
vn_initlist((struct vnlist *)&tvc->v);
tvc->lastr = 0;
#endif /* AFS_SGI_ENV */
tvc->dchint = NULL;
osi_dnlc_purgedp(tvc); /* this may be overkill */
memset(&(tvc->callsort), 0, sizeof(struct afs_q));
tvc->slocks = NULL;
tvc->f.states &=~ CVInit;
if (seq) {
tvc->f.states |= CBulkFetching;
tvc->f.m.Length = seq;
}
afs_osi_Wakeup(&tvc->f.states);
return tvc; return tvc;
} /*afs_NewVCache */ } /*afs_NewVCache */
@ -3165,14 +2825,10 @@ afs_vcacheInit(int astatSize)
register struct vcache *tvp; register struct vcache *tvp;
#endif #endif
int i; int i;
#if defined(AFS_LINUX22_ENV)
if (!afs_maxvcount) { if (!afs_maxvcount) {
afs_maxvcount = astatSize; /* no particular limit on linux? */ afs_maxvcount = astatSize; /* no particular limit on linux? */
if (astatSize < afs_maxvcount) {
afs_maxvcount = astatSize;
}
} }
#else /* AFS_LINUX22_ENV */ #if !defined(AFS_LINUX22_ENV)
freeVCList = NULL; freeVCList = NULL;
#endif #endif

2
src/libafs/Makefile.common.in
View File

@ -524,6 +524,8 @@ osi_pagecopy.o: $(TOP_SRCDIR)/afs/$(MKAFS_OSTYPE)/osi_pagecopy.c
$(CRULE_NOOPT) $(CRULE_NOOPT)
osi_fetchstore.o: $(TOP_SRCDIR)/afs/$(MKAFS_OSTYPE)/osi_fetchstore.c osi_fetchstore.o: $(TOP_SRCDIR)/afs/$(MKAFS_OSTYPE)/osi_fetchstore.c
$(CRULE_NOOPT) $(CRULE_NOOPT)
osi_vcache.o: $(TOP_SRCDIR)/afs/$(MKAFS_OSTYPE)/osi_vcache.c
$(CRULE_NOOPT)
clean: clean:
-$(RM) -rf STATIC* MODLOAD* $(AFS_OS_CLEAN) -$(RM) -rf STATIC* MODLOAD* $(AFS_OS_CLEAN)

1
src/libafs/MakefileProto.AIX.in
View File

@ -23,6 +23,7 @@ AFS_OS_OBJS = \
osi_misc.o \ osi_misc.o \
osi_sleep.o \ osi_sleep.o \
osi_timeout.o \ osi_timeout.o \
osi_vcache.o \
osi_vm.o osi_vm.o
AFSNOIAUTHOBJS = \ AFSNOIAUTHOBJS = \

1
src/libafs/MakefileProto.DARWIN.in
View File

@ -24,6 +24,7 @@ AFS_OS_OBJS = \
osi_gcpags.o \ osi_gcpags.o \
osi_groups.o \ osi_groups.o \
osi_sleep.o \ osi_sleep.o \
osi_vcache.o \
osi_vm.o \ osi_vm.o \
osi_vnodeops.o \ osi_vnodeops.o \
osi_module.o osi_module.o

1
src/libafs/MakefileProto.DFBSD.in
View File

@ -17,6 +17,7 @@ AFS_OS_OBJS = \
osi_inode.o \ osi_inode.o \
osi_misc.o \ osi_misc.o \
osi_sleep.o \ osi_sleep.o \
osi_vcache.o \
osi_vm.o \ osi_vm.o \
osi_vnodeops.o \ osi_vnodeops.o \
osi_module.o osi_module.o

1
src/libafs/MakefileProto.DUX.in
View File

@ -21,6 +21,7 @@ AFS_OS_OBJS = \
osi_inode.o \ osi_inode.o \
osi_misc.o \ osi_misc.o \
osi_sleep.o \ osi_sleep.o \
osi_vcache.o \
osi_vm.o \ osi_vm.o \
osi_vnodeops.o osi_vnodeops.o

1
src/libafs/MakefileProto.FBSD.in
View File

@ -21,6 +21,7 @@ AFS_OS_OBJS = \
osi_inode.o \ osi_inode.o \
osi_misc.o \ osi_misc.o \
osi_sleep.o \ osi_sleep.o \
osi_vcache.o \
osi_vm.o \ osi_vm.o \
osi_vnodeops.o \ osi_vnodeops.o \
osi_module.o osi_module.o

1
src/libafs/MakefileProto.HPUX.in
View File

@ -22,6 +22,7 @@ AFS_OS_OBJS = \
osi_file.o \ osi_file.o \
osi_misc.o \ osi_misc.o \
osi_sleep.o \ osi_sleep.o \
osi_vcache.o \
osi_vnodeops.o \ osi_vnodeops.o \
osi_vm.o osi_vm.o

1
src/libafs/MakefileProto.IRIX.in
View File

@ -23,6 +23,7 @@ AFS_OS_OBJS = \
osi_inode.o \ osi_inode.o \
osi_misc.o \ osi_misc.o \
osi_sleep.o \ osi_sleep.o \
osi_vcache.o \
osi_vm.o \ osi_vm.o \
osi_vnodeops.o osi_vnodeops.o

1
src/libafs/MakefileProto.LINUX.in
View File

@ -33,6 +33,7 @@ AFS_OS_OBJS = \
osi_sleep.o \ osi_sleep.o \
osi_syscall.o \ osi_syscall.o \
osi_sysctl.o \ osi_sysctl.o \
osi_vcache.o \
osi_vfsops.o \ osi_vfsops.o \
osi_vm.o \ osi_vm.o \
<ppc64_linux26> <ppc64_linux26>

1
src/libafs/MakefileProto.NBSD.in
View File

@ -21,6 +21,7 @@ AFS_OS_OBJS = \
osi_inode.o \ osi_inode.o \
osi_misc.o \ osi_misc.o \
osi_sleep.o \ osi_sleep.o \
osi_vcache.o \
osi_vm.o \ osi_vm.o \
osi_vnodeops.o osi_vnodeops.o

1
src/libafs/MakefileProto.OBSD.in
View File

@ -41,6 +41,7 @@ AFS_OS_OBJS = \
osi_file.o \ osi_file.o \
osi_misc.o \ osi_misc.o \
osi_sleep.o \ osi_sleep.o \
osi_vcache.o \
osi_vm.o \ osi_vm.o \
osi_vnodeops.o osi_vnodeops.o

1
src/libafs/MakefileProto.SOLARIS.in
View File

@ -20,6 +20,7 @@ AFS_OS_OBJS = \
osi_inode.o \ osi_inode.o \
osi_file.o \ osi_file.o \
osi_sleep.o \ osi_sleep.o \
osi_vcache.o \
osi_vm.o \ osi_vm.o \
osi_vnodeops.o osi_vnodeops.o

10
src/libuafs/Makefile.common.in
View File

@ -146,6 +146,7 @@ UAFSOBJ = \
$(UOBJ)/osi_vm.o \ $(UOBJ)/osi_vm.o \
$(UOBJ)/osi_groups.o \ $(UOBJ)/osi_groups.o \
$(UOBJ)/osi_gcpags.o \ $(UOBJ)/osi_gcpags.o \
$(UOBJ)/osi_vcache.o \
$(UOBJ)/afsaux.o \ $(UOBJ)/afsaux.o \
$(UOBJ)/Kvice.xdr.o \ $(UOBJ)/Kvice.xdr.o \
$(UOBJ)/xdr_arrayn.o \ $(UOBJ)/xdr_arrayn.o \
@ -281,6 +282,7 @@ AFSWEBOBJ = \
$(WEBOBJ)/osi_vm.o \ $(WEBOBJ)/osi_vm.o \
$(WEBOBJ)/osi_groups.o \ $(WEBOBJ)/osi_groups.o \
$(WEBOBJ)/osi_gcpags.o \ $(WEBOBJ)/osi_gcpags.o \
$(WEBOBJ)/osi_vcache.o \
$(WEBOBJ)/afsaux.o \ $(WEBOBJ)/afsaux.o \
$(WEBOBJ)/Kvice.xdr.o \ $(WEBOBJ)/Kvice.xdr.o \
$(WEBOBJ)/xdr_arrayn.o \ $(WEBOBJ)/xdr_arrayn.o \
@ -412,6 +414,7 @@ AFSWEBOBJKRB = \
$(WEBOBJ)/osi_vm.o \ $(WEBOBJ)/osi_vm.o \
$(WEBOBJ)/osi_groups.o \ $(WEBOBJ)/osi_groups.o \
$(WEBOBJ)/osi_gcpags.o \ $(WEBOBJ)/osi_gcpags.o \
$(WEBOBJ)/osi_vcache.o \
$(WEBOBJ)/afsaux.o \ $(WEBOBJ)/afsaux.o \
$(WEBOBJ)/Kvice.xdr.o \ $(WEBOBJ)/Kvice.xdr.o \
$(WEBOBJ)/xdr_arrayn.o \ $(WEBOBJ)/xdr_arrayn.o \
@ -546,6 +549,7 @@ JUAFSOBJ = \
$(JUAFS)/osi_vm.o \ $(JUAFS)/osi_vm.o \
$(JUAFS)/osi_groups.o \ $(JUAFS)/osi_groups.o \
$(JUAFS)/osi_gcpags.o \ $(JUAFS)/osi_gcpags.o \
$(JUAFS)/osi_vcache.o \
$(JUAFS)/afsaux.o \ $(JUAFS)/afsaux.o \
$(JUAFS)/Kvice.xdr.o \ $(JUAFS)/Kvice.xdr.o \
$(JUAFS)/xdr_arrayn.o \ $(JUAFS)/xdr_arrayn.o \
@ -784,6 +788,8 @@ $(UOBJ)/osi_groups.o: $(TOP_SRC_AFS)/UKERNEL/osi_groups.c
$(CRULE1) $(CRULE1)
$(UOBJ)/osi_gcpags.o: $(TOP_SRC_AFS)/UKERNEL/osi_gcpags.c $(UOBJ)/osi_gcpags.o: $(TOP_SRC_AFS)/UKERNEL/osi_gcpags.c
$(CRULE1) $(CRULE1)
$(UOBJ)/osi_vcache.o: $(TOP_SRC_AFS)/UKERNEL/osi_vcache.c
$(CRULE1)
$(UOBJ)/Kcallback.ss.o: $(TOP_OBJ_FSINT)/Kcallback.ss.c $(UOBJ)/Kcallback.ss.o: $(TOP_OBJ_FSINT)/Kcallback.ss.c
$(CRULE1) $(CRULE1)
$(UOBJ)/Kvice.xdr.o: $(TOP_OBJ_FSINT)/Kvice.xdr.c $(UOBJ)/Kvice.xdr.o: $(TOP_OBJ_FSINT)/Kvice.xdr.c
@ -1057,6 +1063,8 @@ $(WEBOBJ)/osi_groups.o: $(TOP_SRC_AFS)/UKERNEL/osi_groups.c
$(CRULE2) $(CRULE2)
$(WEBOBJ)/osi_gcpags.o: $(TOP_SRC_AFS)/UKERNEL/osi_gcpags.c $(WEBOBJ)/osi_gcpags.o: $(TOP_SRC_AFS)/UKERNEL/osi_gcpags.c
$(CRULE2) $(CRULE2)
$(WEBOBJ)/osi_vcache.o: $(TOP_SRC_AFS)/UKERNEL/osi_vcache.c
$(CRULE2)
$(WEBOBJ)/Kcallback.ss.o: $(TOP_OBJ_FSINT)/Kcallback.ss.c $(WEBOBJ)/Kcallback.ss.o: $(TOP_OBJ_FSINT)/Kcallback.ss.c
$(CRULE2) $(CRULE2)
$(WEBOBJ)/Kvice.xdr.o: $(TOP_OBJ_FSINT)/Kvice.xdr.c $(WEBOBJ)/Kvice.xdr.o: $(TOP_OBJ_FSINT)/Kvice.xdr.c
@ -1340,6 +1348,8 @@ $(JUAFS)/osi_groups.o: $(TOP_SRC_AFS)/UKERNEL/osi_groups.c
$(CRULE1) $(CRULE1)
$(JUAFS)/osi_gcpags.o: $(TOP_SRC_AFS)/UKERNEL/osi_gcpags.c $(JUAFS)/osi_gcpags.o: $(TOP_SRC_AFS)/UKERNEL/osi_gcpags.c
$(CRULE1) $(CRULE1)
$(JUAFS)/osi_vcache.o: $(TOP_SRC_AFS)/UKERNEL/osi_vcache.c
$(CRULE1)
$(JUAFS)/Kcallback.ss.o: $(TOP_OBJ_FSINT)/Kcallback.ss.c $(JUAFS)/Kcallback.ss.o: $(TOP_OBJ_FSINT)/Kcallback.ss.c
$(CRULE1) $(CRULE1)
$(JUAFS)/Kvice.xdr.o: $(TOP_OBJ_FSINT)/Kvice.xdr.c $(JUAFS)/Kvice.xdr.o: $(TOP_OBJ_FSINT)/Kvice.xdr.c