* [PATCH 3/5] CIFS: Add cifs_set_oplock_level
@ 2010-10-31 19:43 Pavel Shilovsky
[not found] ` <AANLkTimZ-yN16TVAtiSjcB-Pw5KV3iSMOA1BrkbUio6Y-JsoAwUIsXosN+BqQ9rBEUg@public.gmane.org>
0 siblings, 1 reply; 2+ messages in thread
From: Pavel Shilovsky @ 2010-10-31 19:43 UTC (permalink / raw)
To: linux-cifs-u79uwXL29TY76Z2rM5mHXA
Simplify many places when we need to set oplock level on an inode.
Signed-off-by: Pavel Shilovsky <piastryyy-Re5JQEeQqe8AvxtiuMwx3w@public.gmane.org>
---
fs/cifs/cifsproto.h | 1 +
fs/cifs/file.c | 38 +++++++++-----------------------------
fs/cifs/misc.c | 23 ++++++++++++++++++++---
3 files changed, 30 insertions(+), 32 deletions(-)
diff --git a/fs/cifs/cifsproto.h b/fs/cifs/cifsproto.h
index e593c40..086fbfe 100644
--- a/fs/cifs/cifsproto.h
+++ b/fs/cifs/cifsproto.h
@@ -104,6 +104,7 @@ extern struct timespec cifs_NTtimeToUnix(__le64
utc_nanoseconds_since_1601);
extern u64 cifs_UnixTimeToNT(struct timespec);
extern struct timespec cnvrtDosUnixTm(__le16 le_date, __le16 le_time,
int offset);
+extern void cifs_set_oplock_level(struct inode *inode, __u32 oplock);
extern struct cifsFileInfo *cifs_new_fileinfo(__u16 fileHandle,
struct file *file, struct tcon_link *tlink,
diff --git a/fs/cifs/file.c b/fs/cifs/file.c
index 6edeb5b..0f63978 100644
--- a/fs/cifs/file.c
+++ b/fs/cifs/file.c
@@ -146,12 +146,7 @@ client_can_cache:
rc = cifs_get_inode_info(&inode, full_path, buf, inode->i_sb,
xid, NULL);
- if ((oplock & 0xF) == OPLOCK_EXCLUSIVE) {
- pCifsInode->clientCanCacheAll = true;
- pCifsInode->clientCanCacheRead = true;
- cFYI(1, "Exclusive Oplock granted on inode %p", inode);
- } else if ((oplock & 0xF) == OPLOCK_READ)
- pCifsInode->clientCanCacheRead = true;
+ cifs_set_oplock_level(inode, oplock);
return rc;
}
@@ -253,12 +248,7 @@ cifs_new_fileinfo(__u16 fileHandle, struct file *file,
list_add_tail(&pCifsFile->flist, &pCifsInode->openFileList);
spin_unlock(&cifs_file_list_lock);
- if ((oplock & 0xF) == OPLOCK_EXCLUSIVE) {
- pCifsInode->clientCanCacheAll = true;
- pCifsInode->clientCanCacheRead = true;
- cFYI(1, "Exclusive Oplock inode %p", inode);
- } else if ((oplock & 0xF) == OPLOCK_READ)
- pCifsInode->clientCanCacheRead = true;
+ cifs_set_oplock_level(inode, oplock);
file->private_data = pCifsFile;
return pCifsFile;
@@ -271,8 +261,10 @@ cifs_new_fileinfo(__u16 fileHandle, struct file *file,
*/
void cifsFileInfo_put(struct cifsFileInfo *cifs_file)
{
+ struct inode *inode = cifs_file->dentry->d_inode;
struct cifsTconInfo *tcon = tlink_tcon(cifs_file->tlink);
- struct cifsInodeInfo *cifsi = CIFS_I(cifs_file->dentry->d_inode);
+ struct cifsInodeInfo *cifsi = CIFS_I(inode);
+ struct cifs_sb_info *cifs_sb = CIFS_SB(inode->i_sb);
struct cifsLockInfo *li, *tmp;
spin_lock(&cifs_file_list_lock);
@@ -288,8 +280,7 @@ void cifsFileInfo_put(struct cifsFileInfo *cifs_file)
if (list_empty(&cifsi->openFileList)) {
cFYI(1, "closing last open instance for inode %p",
cifs_file->dentry->d_inode);
- cifsi->clientCanCacheRead = false;
- cifsi->clientCanCacheAll = false;
+ cifs_set_oplock_level(inode, 0);
if (cifs_sb->mnt_cifs_flags & CIFS_MOUNT_STRICT_IO)
invalidate_remote_inode(inode);
}
@@ -609,8 +600,6 @@ reopen_success:
rc = filemap_write_and_wait(inode->i_mapping);
mapping_set_error(inode->i_mapping, rc);
- pCifsInode->clientCanCacheAll = false;
- pCifsInode->clientCanCacheRead = false;
if (tcon->unix_ext)
rc = cifs_get_inode_info_unix(&inode,
full_path, inode->i_sb, xid);
@@ -624,18 +613,9 @@ reopen_success:
invalidate the current end of file on the server
we can not go to the server to get the new inod
info */
- if ((oplock & 0xF) == OPLOCK_EXCLUSIVE) {
- pCifsInode->clientCanCacheAll = true;
- pCifsInode->clientCanCacheRead = true;
- cFYI(1, "Exclusive Oplock granted on inode %p",
- pCifsFile->dentry->d_inode);
- } else if ((oplock & 0xF) == OPLOCK_READ) {
- pCifsInode->clientCanCacheRead = true;
- pCifsInode->clientCanCacheAll = false;
- } else {
- pCifsInode->clientCanCacheRead = false;
- pCifsInode->clientCanCacheAll = false;
- }
+
+ cifs_set_oplock_level(inode, oplock);
+
cifs_relock_file(pCifsFile);
reopen_error_exit:
diff --git a/fs/cifs/misc.c b/fs/cifs/misc.c
index c4e296f..d3b9dde 100644
--- a/fs/cifs/misc.c
+++ b/fs/cifs/misc.c
@@ -569,10 +569,9 @@ is_valid_oplock_break(struct smb_hdr *buf, struct
TCP_Server_Info *srv)
cFYI(1, "file id match, oplock break");
pCifsInode = CIFS_I(netfile->dentry->d_inode);
- pCifsInode->clientCanCacheAll = false;
- if (pSMB->OplockLevel == 0)
- pCifsInode->clientCanCacheRead = false;
+ cifs_set_oplock_level(netfile->dentry->d_inode,
+ pSMB->OplockLevel);
/*
* cifs_oplock_break_put() can't be called
* from here. Get reference after queueing
@@ -722,3 +721,21 @@ cifs_autodisable_serverino(struct cifs_sb_info *cifs_sb)
cifs_sb_master_tcon(cifs_sb)->treeName);
}
}
+
+void cifs_set_oplock_level(struct inode *inode, __u32 oplock)
+{
+ struct cifsInodeInfo *cinode = CIFS_I(inode);
+
+ if ((oplock & 0xF) == OPLOCK_EXCLUSIVE) {
+ cinode->clientCanCacheAll = true;
+ cinode->clientCanCacheRead = true;
+ cFYI(1, "Exclusive Oplock granted on inode %p", inode);
+ } else if ((oplock & 0xF) == OPLOCK_READ) {
+ cinode->clientCanCacheAll = false;
+ cinode->clientCanCacheRead = true;
+ cFYI(1, "Level II Oplock granted on inode %p", inode);
+ } else {
+ cinode->clientCanCacheAll = false;
+ cinode->clientCanCacheRead = false;
+ }
+}
--
1.7.2.3
^ permalink raw reply related [flat|nested] 2+ messages in thread
* Re: [PATCH 3/5] CIFS: Add cifs_set_oplock_level
[not found] ` <AANLkTimZ-yN16TVAtiSjcB-Pw5KV3iSMOA1BrkbUio6Y-JsoAwUIsXosN+BqQ9rBEUg@public.gmane.org>
@ 2010-11-01 13:44 ` Jeff Layton
0 siblings, 0 replies; 2+ messages in thread
From: Jeff Layton @ 2010-11-01 13:44 UTC (permalink / raw)
To: Pavel Shilovsky; +Cc: linux-cifs-u79uwXL29TY76Z2rM5mHXA
On Sun, 31 Oct 2010 22:43:37 +0300
Pavel Shilovsky <piastryyy-Re5JQEeQqe8AvxtiuMwx3w@public.gmane.org> wrote:
> Simplify many places when we need to set oplock level on an inode.
>
> Signed-off-by: Pavel Shilovsky <piastryyy-Re5JQEeQqe8AvxtiuMwx3w@public.gmane.org>
> ---
> fs/cifs/cifsproto.h | 1 +
> fs/cifs/file.c | 38 +++++++++-----------------------------
> fs/cifs/misc.c | 23 ++++++++++++++++++++---
> 3 files changed, 30 insertions(+), 32 deletions(-)
>
> diff --git a/fs/cifs/cifsproto.h b/fs/cifs/cifsproto.h
> index e593c40..086fbfe 100644
> --- a/fs/cifs/cifsproto.h
> +++ b/fs/cifs/cifsproto.h
> @@ -104,6 +104,7 @@ extern struct timespec cifs_NTtimeToUnix(__le64
> utc_nanoseconds_since_1601);
> extern u64 cifs_UnixTimeToNT(struct timespec);
> extern struct timespec cnvrtDosUnixTm(__le16 le_date, __le16 le_time,
> int offset);
> +extern void cifs_set_oplock_level(struct inode *inode, __u32 oplock);
>
> extern struct cifsFileInfo *cifs_new_fileinfo(__u16 fileHandle,
> struct file *file, struct tcon_link *tlink,
> diff --git a/fs/cifs/file.c b/fs/cifs/file.c
> index 6edeb5b..0f63978 100644
> --- a/fs/cifs/file.c
> +++ b/fs/cifs/file.c
> @@ -146,12 +146,7 @@ client_can_cache:
> rc = cifs_get_inode_info(&inode, full_path, buf, inode->i_sb,
> xid, NULL);
>
> - if ((oplock & 0xF) == OPLOCK_EXCLUSIVE) {
> - pCifsInode->clientCanCacheAll = true;
> - pCifsInode->clientCanCacheRead = true;
> - cFYI(1, "Exclusive Oplock granted on inode %p", inode);
> - } else if ((oplock & 0xF) == OPLOCK_READ)
> - pCifsInode->clientCanCacheRead = true;
> + cifs_set_oplock_level(inode, oplock);
>
> return rc;
> }
> @@ -253,12 +248,7 @@ cifs_new_fileinfo(__u16 fileHandle, struct file *file,
> list_add_tail(&pCifsFile->flist, &pCifsInode->openFileList);
> spin_unlock(&cifs_file_list_lock);
>
> - if ((oplock & 0xF) == OPLOCK_EXCLUSIVE) {
> - pCifsInode->clientCanCacheAll = true;
> - pCifsInode->clientCanCacheRead = true;
> - cFYI(1, "Exclusive Oplock inode %p", inode);
> - } else if ((oplock & 0xF) == OPLOCK_READ)
> - pCifsInode->clientCanCacheRead = true;
> + cifs_set_oplock_level(inode, oplock);
>
> file->private_data = pCifsFile;
> return pCifsFile;
> @@ -271,8 +261,10 @@ cifs_new_fileinfo(__u16 fileHandle, struct file *file,
> */
> void cifsFileInfo_put(struct cifsFileInfo *cifs_file)
> {
> + struct inode *inode = cifs_file->dentry->d_inode;
> struct cifsTconInfo *tcon = tlink_tcon(cifs_file->tlink);
> - struct cifsInodeInfo *cifsi = CIFS_I(cifs_file->dentry->d_inode);
> + struct cifsInodeInfo *cifsi = CIFS_I(inode);
> + struct cifs_sb_info *cifs_sb = CIFS_SB(inode->i_sb);
> struct cifsLockInfo *li, *tmp;
>
> spin_lock(&cifs_file_list_lock);
> @@ -288,8 +280,7 @@ void cifsFileInfo_put(struct cifsFileInfo *cifs_file)
> if (list_empty(&cifsi->openFileList)) {
> cFYI(1, "closing last open instance for inode %p",
> cifs_file->dentry->d_inode);
> - cifsi->clientCanCacheRead = false;
> - cifsi->clientCanCacheAll = false;
> + cifs_set_oplock_level(inode, 0);
> if (cifs_sb->mnt_cifs_flags & CIFS_MOUNT_STRICT_IO)
> invalidate_remote_inode(inode);
> }
> @@ -609,8 +600,6 @@ reopen_success:
> rc = filemap_write_and_wait(inode->i_mapping);
> mapping_set_error(inode->i_mapping, rc);
>
> - pCifsInode->clientCanCacheAll = false;
> - pCifsInode->clientCanCacheRead = false;
> if (tcon->unix_ext)
> rc = cifs_get_inode_info_unix(&inode,
> full_path, inode->i_sb, xid);
> @@ -624,18 +613,9 @@ reopen_success:
> invalidate the current end of file on the server
> we can not go to the server to get the new inod
> info */
> - if ((oplock & 0xF) == OPLOCK_EXCLUSIVE) {
> - pCifsInode->clientCanCacheAll = true;
> - pCifsInode->clientCanCacheRead = true;
> - cFYI(1, "Exclusive Oplock granted on inode %p",
> - pCifsFile->dentry->d_inode);
> - } else if ((oplock & 0xF) == OPLOCK_READ) {
> - pCifsInode->clientCanCacheRead = true;
> - pCifsInode->clientCanCacheAll = false;
> - } else {
> - pCifsInode->clientCanCacheRead = false;
> - pCifsInode->clientCanCacheAll = false;
> - }
> +
> + cifs_set_oplock_level(inode, oplock);
> +
> cifs_relock_file(pCifsFile);
>
> reopen_error_exit:
> diff --git a/fs/cifs/misc.c b/fs/cifs/misc.c
> index c4e296f..d3b9dde 100644
> --- a/fs/cifs/misc.c
> +++ b/fs/cifs/misc.c
> @@ -569,10 +569,9 @@ is_valid_oplock_break(struct smb_hdr *buf, struct
> TCP_Server_Info *srv)
>
> cFYI(1, "file id match, oplock break");
> pCifsInode = CIFS_I(netfile->dentry->d_inode);
> - pCifsInode->clientCanCacheAll = false;
> - if (pSMB->OplockLevel == 0)
> - pCifsInode->clientCanCacheRead = false;
>
> + cifs_set_oplock_level(netfile->dentry->d_inode,
> + pSMB->OplockLevel);
> /*
> * cifs_oplock_break_put() can't be called
> * from here. Get reference after queueing
> @@ -722,3 +721,21 @@ cifs_autodisable_serverino(struct cifs_sb_info *cifs_sb)
> cifs_sb_master_tcon(cifs_sb)->treeName);
> }
> }
> +
> +void cifs_set_oplock_level(struct inode *inode, __u32 oplock)
> +{
> + struct cifsInodeInfo *cinode = CIFS_I(inode);
> +
> + if ((oplock & 0xF) == OPLOCK_EXCLUSIVE) {
> + cinode->clientCanCacheAll = true;
> + cinode->clientCanCacheRead = true;
> + cFYI(1, "Exclusive Oplock granted on inode %p", inode);
> + } else if ((oplock & 0xF) == OPLOCK_READ) {
> + cinode->clientCanCacheAll = false;
> + cinode->clientCanCacheRead = true;
> + cFYI(1, "Level II Oplock granted on inode %p", inode);
> + } else {
> + cinode->clientCanCacheAll = false;
> + cinode->clientCanCacheRead = false;
> + }
> +}
Nice cleanup, but there will be merge conflicts as the first patch in
this series shouldn't be merged as-is.
Reviewed-by: Jeff Layton <jlayton-H+wXaHxf7aLQT0dZR+AlfA@public.gmane.org>
^ permalink raw reply [flat|nested] 2+ messages in thread
end of thread, other threads:[~2010-11-01 13:44 UTC | newest]
Thread overview: 2+ messages (download: mbox.gz / follow: Atom feed)
-- links below jump to the message on this page --
2010-10-31 19:43 [PATCH 3/5] CIFS: Add cifs_set_oplock_level Pavel Shilovsky
[not found] ` <AANLkTimZ-yN16TVAtiSjcB-Pw5KV3iSMOA1BrkbUio6Y-JsoAwUIsXosN+BqQ9rBEUg@public.gmane.org>
2010-11-01 13:44 ` Jeff Layton
This is an external index of several public inboxes,
see mirroring instructions on how to clone and mirror
all data and code used by this external index.