#include "afs/afs_stats.h"
#include "afs/afs_osidnlc.h"
#include "h/mm.h"
+#ifdef HAVE_MM_INLINE_H
+#include "h/mm_inline.h"
+#endif
#include "h/pagemap.h"
#if defined(AFS_LINUX24_ENV)
#include "h/smp_lock.h"
cred_t *credp = crref();
struct afs_fakestat_state fakestat;
- AFS_GLOCK();
#if defined(AFS_LINUX26_ENV)
lock_kernel();
#endif
+ AFS_GLOCK();
AFS_STATCNT(afs_readdir);
code = afs_InitReq(&treq, credp);
code = 0;
offset = (int) fp->f_pos;
while (1) {
- dirpos = BlobScan(&tdc->f.inode, offset);
+ dirpos = BlobScan(&tdc->f, offset);
if (!dirpos)
break;
- de = afs_dir_GetBlob(&tdc->f.inode, dirpos);
+ de = afs_dir_GetBlob(&tdc->f, dirpos);
if (!de)
break;
out:
afs_PutFakeStat(&fakestat);
out1:
+ AFS_GUNLOCK();
#if defined(AFS_LINUX26_ENV)
unlock_kernel();
#endif
- AFS_GUNLOCK();
return code;
}
int code;
cred_t *credp = crref();
- AFS_GLOCK();
#ifdef AFS_LINUX24_ENV
lock_kernel();
#endif
+ AFS_GLOCK();
code = afs_open((struct vcache **)&ip, fp->f_flags, credp);
+ AFS_GUNLOCK();
#ifdef AFS_LINUX24_ENV
unlock_kernel();
#endif
- AFS_GUNLOCK();
crfree(credp);
return -code;
cred_t *credp = crref();
struct vcache *vcp = ITOAFS(ip);
- AFS_GLOCK();
#ifdef AFS_LINUX24_ENV
lock_kernel();
#endif
+ AFS_GLOCK();
if (vcp->flushcnt) {
vcp->flushcnt--; /* protected by AFS global lock. */
} else {
code = afs_close(vcp, fp->f_flags, credp);
}
+ AFS_GUNLOCK();
#ifdef AFS_LINUX24_ENV
unlock_kernel();
#endif
- AFS_GUNLOCK();
crfree(credp);
return -code;
struct inode *ip = FILE_INODE(fp);
cred_t *credp = crref();
- AFS_GLOCK();
#ifdef AFS_LINUX24_ENV
lock_kernel();
#endif
+ AFS_GLOCK();
code = afs_fsync(ITOAFS(ip), credp);
+ AFS_GUNLOCK();
#ifdef AFS_LINUX24_ENV
unlock_kernel();
#endif
- AFS_GUNLOCK();
crfree(credp);
return -code;
int code = 0;
struct vcache *vcp = ITOAFS(FILE_INODE(fp));
cred_t *credp = crref();
-#ifdef AFS_LINUX24_ENV
- struct flock64 flock;
-#else
- struct flock flock;
-#endif
-
+ struct AFS_FLOCK flock;
/* Convert to a lock format afs_lockctl understands. */
memset((char *)&flock, 0, sizeof(flock));
flock.l_type = flp->fl_type;
struct vcache *vcp = ITOAFS(dp->d_inode);
struct vcache *rootvp = NULL;
+#ifdef AFS_LINUX24_ENV
+ lock_kernel();
+#endif
AFS_GLOCK();
if (afs_fakestat_enable && vcp->mvstat == 1 && vcp->mvid
rootvp = afs_FindVCache(vcp->mvid, 0, 0);
ReleaseSharedLock(&afs_xvcache);
}
-#ifdef AFS_LINUX24_ENV
- lock_kernel();
-#endif
/* Make this a fast path (no crref), since it's called so often. */
if (vcp->states & CStatd) {
vcache2fakeinode(rootvp, vcp);
else
vcache2inode(vcp);
-#ifdef AFS_LINUX24_ENV
- unlock_kernel();
-#endif
if (rootvp)
afs_PutVCache(rootvp);
AFS_GUNLOCK();
+#ifdef AFS_LINUX24_ENV
+ unlock_kernel();
+#endif
return 0;
}
if (!code)
code = afs_VerifyVCache(vcp, &treq);
+ AFS_GUNLOCK();
#ifdef AFS_LINUX24_ENV
unlock_kernel();
#endif
- AFS_GUNLOCK();
crfree(credp);
return -code;
sysState.allocked = 0;
- AFS_GLOCK();
+#ifdef AFS_LINUX24_ENV
lock_kernel();
+#endif
+ AFS_GLOCK();
vcp = ITOAFS(dp->d_inode);
parentvcp = ITOAFS(dp->d_parent->d_inode);
if (sysState.allocked)
osi_FreeLargeSpace(name);
+ AFS_GUNLOCK();
+
if (bad_dentry) {
shrink_dcache_parent(dp);
d_drop(dp);
}
+#ifdef AFS_LINUX24_ENV
unlock_kernel();
- AFS_GUNLOCK();
+#endif
crfree(credp);
return !bad_dentry;
static void
afs_dentry_iput(struct dentry *dp, struct inode *ip)
{
+ int isglock;
+
if (ICL_SETACTIVE(afs_iclSetp)) {
- AFS_GLOCK();
+ isglock = ISAFS_GLOCK();
+ if (!isglock) AFS_GLOCK();
afs_Trace3(afs_iclSetp, CM_TRACE_DENTRYIPUT, ICL_TYPE_POINTER, ip,
ICL_TYPE_STRING, dp->d_parent->d_name.name,
ICL_TYPE_STRING, dp->d_name.name);
- AFS_GUNLOCK();
+ if (!isglock) AFS_GUNLOCK();
}
osi_iput(ip);
static int
afs_dentry_delete(struct dentry *dp)
{
+ int isglock;
if (ICL_SETACTIVE(afs_iclSetp)) {
- AFS_GLOCK();
+ isglock = ISAFS_GLOCK();
+ if (!isglock) AFS_GLOCK();
afs_Trace3(afs_iclSetp, CM_TRACE_DENTRYDELETE, ICL_TYPE_POINTER,
dp->d_inode, ICL_TYPE_STRING, dp->d_parent->d_name.name,
ICL_TYPE_STRING, dp->d_name.name);
- AFS_GUNLOCK();
+ if (!isglock) AFS_GUNLOCK();
}
if (dp->d_inode && (ITOAFS(dp->d_inode)->states & CUnlinked))
VATTR_NULL(&vattr);
vattr.va_mode = mode;
- AFS_GLOCK();
#if defined(AFS_LINUX26_ENV)
lock_kernel();
#endif
+ AFS_GLOCK();
code =
afs_create(ITOAFS(dip), name, &vattr, NONEXCL, mode,
(struct vcache **)&ip, credp);
d_instantiate(dp, ip);
}
+ AFS_GUNLOCK();
#if defined(AFS_LINUX26_ENV)
unlock_kernel();
#endif
- AFS_GUNLOCK();
crfree(credp);
return -code;
}
struct vcache *vcp = NULL;
const char *comp = dp->d_name.name;
- AFS_GLOCK();
#if defined(AFS_LINUX26_ENV)
lock_kernel();
#endif
+ AFS_GLOCK();
code = afs_lookup(ITOAFS(dip), comp, &vcp, credp);
+ AFS_GUNLOCK();
if (vcp) {
struct inode *ip = AFSTOI(vcp);
printk
("afs_linux_lookup: ip->i_mode 0x%x dp->d_name.name %s code %d\n",
ip->i_mode, dp->d_name.name, code);
+#ifdef STRUCT_INODE_HAS_I_SECURITY
+ if (ip->i_security == NULL) {
+ if (security_inode_alloc(ip))
+ panic("afs_linux_lookup: Cannot allocate inode security");
+ }
+#endif
#else
if (S_ISDIR(ip->i_mode))
ip->i_op = &afs_dir_iops;
#if defined(AFS_LINUX26_ENV)
unlock_kernel();
#endif
- AFS_GUNLOCK();
crfree(credp);
/* It's ok for the file to not be found. That's noted by the caller by
cred_t *credp = crref();
const char *name = dp->d_name.name;
- AFS_GLOCK();
#if defined(AFS_LINUX26_ENV)
lock_kernel();
#endif
+ AFS_GLOCK();
code = afs_remove(ITOAFS(dip), name, credp);
+ AFS_GUNLOCK();
if (!code)
d_drop(dp);
#if defined(AFS_LINUX26_ENV)
- lock_kernel();
+ unlock_kernel();
#endif
- AFS_GUNLOCK();
crfree(credp);
return -code;
}
struct vattr vattr;
const char *name = dp->d_name.name;
- AFS_GLOCK();
#if defined(AFS_LINUX26_ENV)
lock_kernel();
#endif
+ AFS_GLOCK();
VATTR_NULL(&vattr);
vattr.va_mask = ATTR_MODE;
vattr.va_mode = mode;
code = afs_mkdir(ITOAFS(dip), name, &vattr, &tvcp, credp);
+ AFS_GUNLOCK();
if (tvcp) {
tvcp->v.v_op = &afs_dir_iops;
#if defined(AFS_LINUX26_ENV)
unlock_kernel();
#endif
- AFS_GUNLOCK();
crfree(credp);
return -code;
}
cred_t *credp = crref();
const char *name = dp->d_name.name;
- AFS_GLOCK();
#if defined(AFS_LINUX26_ENV)
lock_kernel();
#endif
+ AFS_GLOCK();
code = afs_rmdir(ITOAFS(dip), name, credp);
+ AFS_GUNLOCK();
/* Linux likes to see ENOTEMPTY returned from an rmdir() syscall
* that failed because a directory is not empty. So, we map
#if defined(AFS_LINUX26_ENV)
unlock_kernel();
#endif
- AFS_GUNLOCK();
crfree(credp);
return -code;
}
const char *oldname = olddp->d_name.name;
const char *newname = newdp->d_name.name;
- AFS_GLOCK();
#if defined(AFS_LINUX26_ENV)
lock_kernel();
#endif
if (!list_empty(&newdp->d_hash))
d_drop(newdp);
#endif
+ AFS_GLOCK();
code = afs_rename(ITOAFS(oldip), oldname, ITOAFS(newip), newname, credp);
+ AFS_GUNLOCK();
if (!code) {
/* update time so it doesn't expire immediately */
#if defined(AFS_LINUX26_ENV)
unlock_kernel();
#endif
- AFS_GUNLOCK();
crfree(credp);
return -code;
int cnt = page_count(pp);
struct vcache *avc = ITOAFS(ip);
- AFS_GLOCK();
- afs_Trace4(afs_iclSetp, CM_TRACE_READPAGE, ICL_TYPE_POINTER, ip, ICL_TYPE_POINTER, pp, ICL_TYPE_INT32, cnt, ICL_TYPE_INT32, 99999); /* not a possible code value */
+
#if LINUX_VERSION_CODE >= KERNEL_VERSION(2,4,0)
address = kmap(pp);
ClearPageError(pp);
-
- lock_kernel();
#else
atomic_add(1, &pp->count);
set_bit(PG_locked, &pp->flags); /* other bits? See mm.h */
setup_uio(&tuio, &iovec, (char *)address, offset, PAGESIZE, UIO_READ,
AFS_UIOSYS);
+#ifdef AFS_LINUX24_ENV
+ lock_kernel();
+#endif
+ AFS_GLOCK();
+ afs_Trace4(afs_iclSetp, CM_TRACE_READPAGE, ICL_TYPE_POINTER, ip, ICL_TYPE_POINTER, pp, ICL_TYPE_INT32, cnt, ICL_TYPE_INT32, 99999); /* not a possible code value */
code = afs_rdwr(avc, &tuio, UIO_READ, 0, credp);
-#if LINUX_VERSION_CODE >= KERNEL_VERSION(2,4,0)
+ afs_Trace4(afs_iclSetp, CM_TRACE_READPAGE, ICL_TYPE_POINTER, ip,
+ ICL_TYPE_POINTER, pp, ICL_TYPE_INT32, cnt, ICL_TYPE_INT32,
+ code);
+ AFS_GUNLOCK();
+#ifdef AFS_LINUX24_ENV
unlock_kernel();
#endif
set_bit(PG_uptodate, &pp->flags);
#endif
}
+
#if LINUX_VERSION_CODE >= KERNEL_VERSION(2,4,0)
kunmap(pp);
UnlockPage(pp);
struct dcache *tdc;
struct vrequest treq;
+ AFS_GLOCK();
code = afs_InitReq(&treq, credp);
if (!code && !NBObtainWriteLock(&avc->lock, 534)) {
tdc = afs_FindDCache(avc, offset);
}
ReleaseWriteLock(&avc->lock);
}
+ AFS_GUNLOCK();
}
crfree(credp);
- afs_Trace4(afs_iclSetp, CM_TRACE_READPAGE, ICL_TYPE_POINTER, ip,
- ICL_TYPE_POINTER, pp, ICL_TYPE_INT32, cnt, ICL_TYPE_INT32,
- code);
- AFS_GUNLOCK();
return -code;
}
{
int code;
- AFS_GLOCK();
lock_kernel();
+ AFS_GLOCK();
code = afs_linux_updatepage(file, page, offset, to - offset);
- unlock_kernel();
AFS_GUNLOCK();
+ unlock_kernel();
kunmap(page);
return code;
char *p = (char *)kmap(page);
int code;
- AFS_GLOCK();
lock_kernel();
+ AFS_GLOCK();
code = afs_linux_ireadlink(ip, p, PAGE_SIZE, AFS_UIOSYS);
+ AFS_GUNLOCK();
if (code < 0)
goto fail;
p[code] = '\0'; /* null terminate? */
unlock_kernel();
- AFS_GUNLOCK();
SetPageUptodate(page);
kunmap(page);
fail:
unlock_kernel();
- AFS_GUNLOCK();
SetPageError(page);
kunmap(page);
git://git.openafs.org / openafs.git / blobdiff