jimzah/openafs
1
0
Fork 0
mirror of https://git.openafs.org/openafs.git synced 2025-02-01 14:07:39 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Windows: optimize buf_FlushCleanPages

Browse Source 
If the pages to be flushed are from a readonly or backup volume
they can't be dirty.  In this case there is no need to stabilize
the pages before they are locked and recycled.

Stablilization is performed on the cm_scache_t object so do not
stabilize and unstablize for each cm_buf_t object.

LICENSE MIT

Change-Id: I6fa86cf0a33dc9f45d77911909e799c0fc6510cf
Reviewed-on: http://gerrit.openafs.org/2518
Tested-by: Jeffrey Altman <jaltman@openafs.org>
Reviewed-by: Jeffrey Altman <jaltman@openafs.org>
This commit is contained in:
Jeffrey Altman 2010-08-05 01:43:24 -04:00 committed by Jeffrey Altman
parent f08e953e62
commit f6a91a28cc
1 changed files with 18 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
src/WINNT/afsd/cm_buf.c
View File

@ -1655,6 +1655,7 @@ long buf_FlushCleanPages(cm_scache_t *scp, cm_user_t *userp, cm_req_t *reqp)
cm_buf_t *nbp; cm_buf_t *nbp;
int didRelease; int didRelease;
afs_uint32 i; afs_uint32 i;
afs_uint32 stable = 0;
i = BUF_FILEHASH(&scp->fid); i = BUF_FILEHASH(&scp->fid);
@ -1670,6 +1671,17 @@ long buf_FlushCleanPages(cm_scache_t *scp, cm_user_t *userp, cm_req_t *reqp)
/* clean buffer synchronously */ /* clean buffer synchronously */
if (cm_FidCmp(&bp->fid, &scp->fid) == 0) { if (cm_FidCmp(&bp->fid, &scp->fid) == 0) {
/*
* if the object is not located on a read/write volume
* we must stabilize the object to ensure that buffer
* changes cannot occur while the flush is performed.
*/
if (!stable && code == 0 && !(scp->flags & CM_SCACHEFLAG_RO)) {
code = (*cm_buf_opsp->Stabilizep)(scp, userp, reqp);
stable = (code == 0);
}
lock_ObtainMutex(&bp->mx); lock_ObtainMutex(&bp->mx);
/* start cleaning the buffer, and wait for it to finish */ /* start cleaning the buffer, and wait for it to finish */
@ -1677,16 +1689,6 @@ long buf_FlushCleanPages(cm_scache_t *scp, cm_user_t *userp, cm_req_t *reqp)
buf_WaitIO(scp, bp); buf_WaitIO(scp, bp);
lock_ReleaseMutex(&bp->mx); lock_ReleaseMutex(&bp->mx);
/*
* if the error for the previous buffer was BADFD
* then all buffers for the FID are bad. Do not
* attempt to stabalize.
*/
if (code != CM_ERROR_BADFD) {
code = (*cm_buf_opsp->Stabilizep)(scp, userp, reqp);
if (code && code != CM_ERROR_BADFD)
goto skip;
}
if (code == CM_ERROR_BADFD) { if (code == CM_ERROR_BADFD) {
/* if the scp's FID is bad its because we received VNOVNODE /* if the scp's FID is bad its because we received VNOVNODE
* when attempting to FetchStatus before the write. This * when attempting to FetchStatus before the write. This
@ -1701,6 +1703,8 @@ long buf_FlushCleanPages(cm_scache_t *scp, cm_user_t *userp, cm_req_t *reqp)
bp->dataVersion = CM_BUF_VERSION_BAD; /* known bad */ bp->dataVersion = CM_BUF_VERSION_BAD; /* known bad */
bp->dirtyCounter++; bp->dirtyCounter++;
lock_ReleaseMutex(&bp->mx); lock_ReleaseMutex(&bp->mx);
} else if (!stable && code) {
goto skip;
} }
/* actually, we only know that buffer is clean if ref /* actually, we only know that buffer is clean if ref
@ -1718,9 +1722,6 @@ long buf_FlushCleanPages(cm_scache_t *scp, cm_user_t *userp, cm_req_t *reqp)
} }
lock_ReleaseWrite(&buf_globalLock); lock_ReleaseWrite(&buf_globalLock);
} }
if (code == 0)
(*cm_buf_opsp->Unstabilizep)(scp, userp);
} }
skip: skip:
@ -1734,6 +1735,9 @@ long buf_FlushCleanPages(cm_scache_t *scp, cm_user_t *userp, cm_req_t *reqp)
} }
} /* for loop over a bunch of buffers */ } /* for loop over a bunch of buffers */
if (stable)
(*cm_buf_opsp->Unstabilizep)(scp, userp);
#ifdef TESTING #ifdef TESTING
buf_ValidateBufQueues(); buf_ValidateBufQueues();
#endif /* TESTING */ #endif /* TESTING */