diff options
| -rw-r--r-- | fs/cifs/cifsfs.c | 3 | ||||
| -rw-r--r-- | fs/cifs/cifsfs.h | 3 | ||||
| -rw-r--r-- | fs/cifs/cifsglob.h | 1 | ||||
| -rw-r--r-- | fs/cifs/cifsproto.h | 6 | ||||
| -rw-r--r-- | fs/cifs/cifssmb.c | 135 | ||||
| -rw-r--r-- | fs/cifs/dir.c | 2 | ||||
| -rw-r--r-- | fs/cifs/file.c | 7 | ||||
| -rw-r--r-- | fs/cifs/inode.c | 297 |
8 files changed, 333 insertions, 121 deletions
diff --git a/fs/cifs/cifsfs.c b/fs/cifs/cifsfs.c index 8c6a03627176..5183bc2a1916 100644 --- a/fs/cifs/cifsfs.c +++ b/fs/cifs/cifsfs.c | |||
| @@ -312,6 +312,7 @@ cifs_alloc_inode(struct super_block *sb) | |||
| 312 | cifs_inode->clientCanCacheRead = false; | 312 | cifs_inode->clientCanCacheRead = false; |
| 313 | cifs_inode->clientCanCacheAll = false; | 313 | cifs_inode->clientCanCacheAll = false; |
| 314 | cifs_inode->delete_pending = false; | 314 | cifs_inode->delete_pending = false; |
| 315 | cifs_inode->invalid_mapping = false; | ||
| 315 | cifs_inode->vfs_inode.i_blkbits = 14; /* 2**14 = CIFS_MAX_MSGSIZE */ | 316 | cifs_inode->vfs_inode.i_blkbits = 14; /* 2**14 = CIFS_MAX_MSGSIZE */ |
| 316 | cifs_inode->server_eof = 0; | 317 | cifs_inode->server_eof = 0; |
| 317 | 318 | ||
| @@ -638,7 +639,7 @@ static loff_t cifs_llseek(struct file *file, loff_t offset, int origin) | |||
| 638 | setting the revalidate time to zero */ | 639 | setting the revalidate time to zero */ |
| 639 | CIFS_I(file->f_path.dentry->d_inode)->time = 0; | 640 | CIFS_I(file->f_path.dentry->d_inode)->time = 0; |
| 640 | 641 | ||
| 641 | retval = cifs_revalidate(file->f_path.dentry); | 642 | retval = cifs_revalidate_file(file); |
| 642 | if (retval < 0) | 643 | if (retval < 0) |
| 643 | return (loff_t)retval; | 644 | return (loff_t)retval; |
| 644 | } | 645 | } |
diff --git a/fs/cifs/cifsfs.h b/fs/cifs/cifsfs.h index 78c1b86d55f6..7aa57ecdc437 100644 --- a/fs/cifs/cifsfs.h +++ b/fs/cifs/cifsfs.h | |||
| @@ -61,7 +61,8 @@ extern int cifs_mkdir(struct inode *, struct dentry *, int); | |||
| 61 | extern int cifs_rmdir(struct inode *, struct dentry *); | 61 | extern int cifs_rmdir(struct inode *, struct dentry *); |
| 62 | extern int cifs_rename(struct inode *, struct dentry *, struct inode *, | 62 | extern int cifs_rename(struct inode *, struct dentry *, struct inode *, |
| 63 | struct dentry *); | 63 | struct dentry *); |
| 64 | extern int cifs_revalidate(struct dentry *); | 64 | extern int cifs_revalidate_file(struct file *filp); |
| 65 | extern int cifs_revalidate_dentry(struct dentry *); | ||
| 65 | extern int cifs_getattr(struct vfsmount *, struct dentry *, struct kstat *); | 66 | extern int cifs_getattr(struct vfsmount *, struct dentry *, struct kstat *); |
| 66 | extern int cifs_setattr(struct dentry *, struct iattr *); | 67 | extern int cifs_setattr(struct dentry *, struct iattr *); |
| 67 | 68 | ||
diff --git a/fs/cifs/cifsglob.h b/fs/cifs/cifsglob.h index a1c817eb291a..63c89d1d70b5 100644 --- a/fs/cifs/cifsglob.h +++ b/fs/cifs/cifsglob.h | |||
| @@ -389,6 +389,7 @@ struct cifsInodeInfo { | |||
| 389 | bool clientCanCacheRead:1; /* read oplock */ | 389 | bool clientCanCacheRead:1; /* read oplock */ |
| 390 | bool clientCanCacheAll:1; /* read and writebehind oplock */ | 390 | bool clientCanCacheAll:1; /* read and writebehind oplock */ |
| 391 | bool delete_pending:1; /* DELETE_ON_CLOSE is set */ | 391 | bool delete_pending:1; /* DELETE_ON_CLOSE is set */ |
| 392 | bool invalid_mapping:1; /* pagecache is invalid */ | ||
| 392 | u64 server_eof; /* current file size on server */ | 393 | u64 server_eof; /* current file size on server */ |
| 393 | u64 uniqueid; /* server inode number */ | 394 | u64 uniqueid; /* server inode number */ |
| 394 | struct inode vfs_inode; | 395 | struct inode vfs_inode; |
diff --git a/fs/cifs/cifsproto.h b/fs/cifs/cifsproto.h index 88e2bc44ac58..39e47f46dea5 100644 --- a/fs/cifs/cifsproto.h +++ b/fs/cifs/cifsproto.h | |||
| @@ -104,10 +104,12 @@ extern void cifs_fattr_to_inode(struct inode *inode, struct cifs_fattr *fattr); | |||
| 104 | extern struct inode *cifs_iget(struct super_block *sb, | 104 | extern struct inode *cifs_iget(struct super_block *sb, |
| 105 | struct cifs_fattr *fattr); | 105 | struct cifs_fattr *fattr); |
| 106 | 106 | ||
| 107 | extern int cifs_get_file_info(struct file *filp); | ||
| 107 | extern int cifs_get_inode_info(struct inode **pinode, | 108 | extern int cifs_get_inode_info(struct inode **pinode, |
| 108 | const unsigned char *search_path, | 109 | const unsigned char *search_path, |
| 109 | FILE_ALL_INFO *pfile_info, | 110 | FILE_ALL_INFO *pfile_info, |
| 110 | struct super_block *sb, int xid, const __u16 *pfid); | 111 | struct super_block *sb, int xid, const __u16 *pfid); |
| 112 | extern int cifs_get_file_info_unix(struct file *filp); | ||
| 111 | extern int cifs_get_inode_info_unix(struct inode **pinode, | 113 | extern int cifs_get_inode_info_unix(struct inode **pinode, |
| 112 | const unsigned char *search_path, | 114 | const unsigned char *search_path, |
| 113 | struct super_block *sb, int xid); | 115 | struct super_block *sb, int xid); |
| @@ -142,6 +144,8 @@ extern int CIFSFindNext(const int xid, struct cifsTconInfo *tcon, | |||
| 142 | extern int CIFSFindClose(const int, struct cifsTconInfo *tcon, | 144 | extern int CIFSFindClose(const int, struct cifsTconInfo *tcon, |
| 143 | const __u16 search_handle); | 145 | const __u16 search_handle); |
| 144 | 146 | ||
| 147 | extern int CIFSSMBQFileInfo(const int xid, struct cifsTconInfo *tcon, | ||
| 148 | u16 netfid, FILE_ALL_INFO *pFindData); | ||
| 145 | extern int CIFSSMBQPathInfo(const int xid, struct cifsTconInfo *tcon, | 149 | extern int CIFSSMBQPathInfo(const int xid, struct cifsTconInfo *tcon, |
| 146 | const unsigned char *searchName, | 150 | const unsigned char *searchName, |
| 147 | FILE_ALL_INFO *findData, | 151 | FILE_ALL_INFO *findData, |
| @@ -152,6 +156,8 @@ extern int SMBQueryInformation(const int xid, struct cifsTconInfo *tcon, | |||
| 152 | FILE_ALL_INFO *findData, | 156 | FILE_ALL_INFO *findData, |
| 153 | const struct nls_table *nls_codepage, int remap); | 157 | const struct nls_table *nls_codepage, int remap); |
| 154 | 158 | ||
| 159 | extern int CIFSSMBUnixQFileInfo(const int xid, struct cifsTconInfo *tcon, | ||
| 160 | u16 netfid, FILE_UNIX_BASIC_INFO *pFindData); | ||
| 155 | extern int CIFSSMBUnixQPathInfo(const int xid, | 161 | extern int CIFSSMBUnixQPathInfo(const int xid, |
| 156 | struct cifsTconInfo *tcon, | 162 | struct cifsTconInfo *tcon, |
| 157 | const unsigned char *searchName, | 163 | const unsigned char *searchName, |
diff --git a/fs/cifs/cifssmb.c b/fs/cifs/cifssmb.c index 611835899844..7cc7f83e9314 100644 --- a/fs/cifs/cifssmb.c +++ b/fs/cifs/cifssmb.c | |||
| @@ -500,7 +500,7 @@ CIFSSMBNegotiate(unsigned int xid, struct cifsSesInfo *ses) | |||
| 500 | } else if (pSMBr->hdr.WordCount == 13) { | 500 | } else if (pSMBr->hdr.WordCount == 13) { |
| 501 | cERROR(1, ("mount failed, cifs module not built " | 501 | cERROR(1, ("mount failed, cifs module not built " |
| 502 | "with CIFS_WEAK_PW_HASH support")); | 502 | "with CIFS_WEAK_PW_HASH support")); |
| 503 | rc = -EOPNOTSUPP; | 503 | rc = -EOPNOTSUPP; |
| 504 | #endif /* WEAK_PW_HASH */ | 504 | #endif /* WEAK_PW_HASH */ |
| 505 | goto neg_err_exit; | 505 | goto neg_err_exit; |
| 506 | } else if (pSMBr->hdr.WordCount != 17) { | 506 | } else if (pSMBr->hdr.WordCount != 17) { |
| @@ -3230,8 +3230,72 @@ QInfRetry: | |||
| 3230 | return rc; | 3230 | return rc; |
| 3231 | } | 3231 | } |
| 3232 | 3232 | ||
| 3233 | int | ||
| 3234 | CIFSSMBQFileInfo(const int xid, struct cifsTconInfo *tcon, | ||
| 3235 | u16 netfid, FILE_ALL_INFO *pFindData) | ||
| 3236 | { | ||
| 3237 | struct smb_t2_qfi_req *pSMB = NULL; | ||
| 3238 | struct smb_t2_qfi_rsp *pSMBr = NULL; | ||
| 3239 | int rc = 0; | ||
| 3240 | int bytes_returned; | ||
| 3241 | __u16 params, byte_count; | ||
| 3233 | 3242 | ||
| 3243 | QFileInfoRetry: | ||
| 3244 | rc = smb_init(SMB_COM_TRANSACTION2, 15, tcon, (void **) &pSMB, | ||
| 3245 | (void **) &pSMBr); | ||
| 3246 | if (rc) | ||
| 3247 | return rc; | ||
| 3234 | 3248 | ||
| 3249 | params = 2 /* level */ + 2 /* fid */; | ||
| 3250 | pSMB->t2.TotalDataCount = 0; | ||
| 3251 | pSMB->t2.MaxParameterCount = cpu_to_le16(4); | ||
| 3252 | /* BB find exact max data count below from sess structure BB */ | ||
| 3253 | pSMB->t2.MaxDataCount = cpu_to_le16(CIFSMaxBufSize); | ||
| 3254 | pSMB->t2.MaxSetupCount = 0; | ||
| 3255 | pSMB->t2.Reserved = 0; | ||
| 3256 | pSMB->t2.Flags = 0; | ||
| 3257 | pSMB->t2.Timeout = 0; | ||
| 3258 | pSMB->t2.Reserved2 = 0; | ||
| 3259 | pSMB->t2.ParameterOffset = cpu_to_le16(offsetof(struct smb_t2_qfi_req, | ||
| 3260 | Fid) - 4); | ||
| 3261 | pSMB->t2.DataCount = 0; | ||
| 3262 | pSMB->t2.DataOffset = 0; | ||
| 3263 | pSMB->t2.SetupCount = 1; | ||
| 3264 | pSMB->t2.Reserved3 = 0; | ||
| 3265 | pSMB->t2.SubCommand = cpu_to_le16(TRANS2_QUERY_FILE_INFORMATION); | ||
| 3266 | byte_count = params + 1 /* pad */ ; | ||
| 3267 | pSMB->t2.TotalParameterCount = cpu_to_le16(params); | ||
| 3268 | pSMB->t2.ParameterCount = pSMB->t2.TotalParameterCount; | ||
| 3269 | pSMB->InformationLevel = cpu_to_le16(SMB_QUERY_FILE_ALL_INFO); | ||
| 3270 | pSMB->Pad = 0; | ||
| 3271 | pSMB->Fid = netfid; | ||
| 3272 | pSMB->hdr.smb_buf_length += byte_count; | ||
| 3273 | |||
| 3274 | rc = SendReceive(xid, tcon->ses, (struct smb_hdr *) pSMB, | ||
| 3275 | (struct smb_hdr *) pSMBr, &bytes_returned, 0); | ||
| 3276 | if (rc) { | ||
| 3277 | cFYI(1, ("Send error in QPathInfo = %d", rc)); | ||
| 3278 | } else { /* decode response */ | ||
| 3279 | rc = validate_t2((struct smb_t2_rsp *)pSMBr); | ||
| 3280 | |||
| 3281 | if (rc) /* BB add auto retry on EOPNOTSUPP? */ | ||
| 3282 | rc = -EIO; | ||
| 3283 | else if (pSMBr->ByteCount < 40) | ||
| 3284 | rc = -EIO; /* bad smb */ | ||
| 3285 | else if (pFindData) { | ||
| 3286 | __u16 data_offset = le16_to_cpu(pSMBr->t2.DataOffset); | ||
| 3287 | memcpy((char *) pFindData, | ||
| 3288 | (char *) &pSMBr->hdr.Protocol + | ||
| 3289 | data_offset, sizeof(FILE_ALL_INFO)); | ||
| 3290 | } else | ||
| 3291 | rc = -ENOMEM; | ||
| 3292 | } | ||
| 3293 | cifs_buf_release(pSMB); | ||
| 3294 | if (rc == -EAGAIN) | ||
| 3295 | goto QFileInfoRetry; | ||
| 3296 | |||
| 3297 | return rc; | ||
| 3298 | } | ||
| 3235 | 3299 | ||
| 3236 | int | 3300 | int |
| 3237 | CIFSSMBQPathInfo(const int xid, struct cifsTconInfo *tcon, | 3301 | CIFSSMBQPathInfo(const int xid, struct cifsTconInfo *tcon, |
| @@ -3335,6 +3399,75 @@ QPathInfoRetry: | |||
| 3335 | } | 3399 | } |
| 3336 | 3400 | ||
| 3337 | int | 3401 | int |
| 3402 | CIFSSMBUnixQFileInfo(const int xid, struct cifsTconInfo *tcon, | ||
| 3403 | u16 netfid, FILE_UNIX_BASIC_INFO *pFindData) | ||
| 3404 | { | ||
| 3405 | struct smb_t2_qfi_req *pSMB = NULL; | ||
| 3406 | struct smb_t2_qfi_rsp *pSMBr = NULL; | ||
| 3407 | int rc = 0; | ||
| 3408 | int bytes_returned; | ||
| 3409 | __u16 params, byte_count; | ||
| 3410 | |||
| 3411 | UnixQFileInfoRetry: | ||
| 3412 | rc = smb_init(SMB_COM_TRANSACTION2, 15, tcon, (void **) &pSMB, | ||
| 3413 | (void **) &pSMBr); | ||
| 3414 | if (rc) | ||
| 3415 | return rc; | ||
| 3416 | |||
| 3417 | params = 2 /* level */ + 2 /* fid */; | ||
| 3418 | pSMB->t2.TotalDataCount = 0; | ||
| 3419 | pSMB->t2.MaxParameterCount = cpu_to_le16(4); | ||
| 3420 | /* BB find exact max data count below from sess structure BB */ | ||
| 3421 | pSMB->t2.MaxDataCount = cpu_to_le16(CIFSMaxBufSize); | ||
| 3422 | pSMB->t2.MaxSetupCount = 0; | ||
| 3423 | pSMB->t2.Reserved = 0; | ||
| 3424 | pSMB->t2.Flags = 0; | ||
| 3425 | pSMB->t2.Timeout = 0; | ||
| 3426 | pSMB->t2.Reserved2 = 0; | ||
| 3427 | pSMB->t2.ParameterOffset = cpu_to_le16(offsetof(struct smb_t2_qfi_req, | ||
| 3428 | Fid) - 4); | ||
| 3429 | pSMB->t2.DataCount = 0; | ||
| 3430 | pSMB->t2.DataOffset = 0; | ||
| 3431 | pSMB->t2.SetupCount = 1; | ||
| 3432 | pSMB->t2.Reserved3 = 0; | ||
| 3433 | pSMB->t2.SubCommand = cpu_to_le16(TRANS2_QUERY_FILE_INFORMATION); | ||
| 3434 | byte_count = params + 1 /* pad */ ; | ||
| 3435 | pSMB->t2.TotalParameterCount = cpu_to_le16(params); | ||
| 3436 | pSMB->t2.ParameterCount = pSMB->t2.TotalParameterCount; | ||
| 3437 | pSMB->InformationLevel = cpu_to_le16(SMB_QUERY_FILE_UNIX_BASIC); | ||
| 3438 | pSMB->Pad = 0; | ||
| 3439 | pSMB->Fid = netfid; | ||
| 3440 | pSMB->hdr.smb_buf_length += byte_count; | ||
| 3441 | |||
| 3442 | rc = SendReceive(xid, tcon->ses, (struct smb_hdr *) pSMB, | ||
| 3443 | (struct smb_hdr *) pSMBr, &bytes_returned, 0); | ||
| 3444 | if (rc) { | ||
| 3445 | cFYI(1, ("Send error in QPathInfo = %d", rc)); | ||
| 3446 | } else { /* decode response */ | ||
| 3447 | rc = validate_t2((struct smb_t2_rsp *)pSMBr); | ||
| 3448 | |||
| 3449 | if (rc || (pSMBr->ByteCount < sizeof(FILE_UNIX_BASIC_INFO))) { | ||
| 3450 | cERROR(1, ("Malformed FILE_UNIX_BASIC_INFO response.\n" | ||
| 3451 | "Unix Extensions can be disabled on mount " | ||
| 3452 | "by specifying the nosfu mount option.")); | ||
| 3453 | rc = -EIO; /* bad smb */ | ||
| 3454 | } else { | ||
| 3455 | __u16 data_offset = le16_to_cpu(pSMBr->t2.DataOffset); | ||
| 3456 | memcpy((char *) pFindData, | ||
| 3457 | (char *) &pSMBr->hdr.Protocol + | ||
| 3458 | data_offset, | ||
| 3459 | sizeof(FILE_UNIX_BASIC_INFO)); | ||
| 3460 | } | ||
| 3461 | } | ||
| 3462 | |||
| 3463 | cifs_buf_release(pSMB); | ||
| 3464 | if (rc == -EAGAIN) | ||
| 3465 | goto UnixQFileInfoRetry; | ||
| 3466 | |||
| 3467 | return rc; | ||
| 3468 | } | ||
| 3469 | |||
| 3470 | int | ||
| 3338 | CIFSSMBUnixQPathInfo(const int xid, struct cifsTconInfo *tcon, | 3471 | CIFSSMBUnixQPathInfo(const int xid, struct cifsTconInfo *tcon, |
| 3339 | const unsigned char *searchName, | 3472 | const unsigned char *searchName, |
| 3340 | FILE_UNIX_BASIC_INFO *pFindData, | 3473 | FILE_UNIX_BASIC_INFO *pFindData, |
diff --git a/fs/cifs/dir.c b/fs/cifs/dir.c index 6ccf7262d1b7..e9f7ecc2714b 100644 --- a/fs/cifs/dir.c +++ b/fs/cifs/dir.c | |||
| @@ -739,7 +739,7 @@ cifs_d_revalidate(struct dentry *direntry, struct nameidata *nd) | |||
| 739 | int isValid = 1; | 739 | int isValid = 1; |
| 740 | 740 | ||
| 741 | if (direntry->d_inode) { | 741 | if (direntry->d_inode) { |
| 742 | if (cifs_revalidate(direntry)) | 742 | if (cifs_revalidate_dentry(direntry)) |
| 743 | return 0; | 743 | return 0; |
| 744 | } else { | 744 | } else { |
| 745 | cFYI(1, ("neg dentry 0x%p name = %s", | 745 | cFYI(1, ("neg dentry 0x%p name = %s", |
diff --git a/fs/cifs/file.c b/fs/cifs/file.c index 3d8f8a96f5a3..ca2ba7a0193c 100644 --- a/fs/cifs/file.c +++ b/fs/cifs/file.c | |||
| @@ -219,8 +219,8 @@ static inline int cifs_open_inode_helper(struct inode *inode, struct file *file, | |||
| 219 | cFYI(1, ("inode unchanged on server")); | 219 | cFYI(1, ("inode unchanged on server")); |
| 220 | } else { | 220 | } else { |
| 221 | if (file->f_path.dentry->d_inode->i_mapping) { | 221 | if (file->f_path.dentry->d_inode->i_mapping) { |
| 222 | /* BB no need to lock inode until after invalidate | 222 | /* BB no need to lock inode until after invalidate |
| 223 | since namei code should already have it locked? */ | 223 | since namei code should already have it locked? */ |
| 224 | rc = filemap_write_and_wait(file->f_path.dentry->d_inode->i_mapping); | 224 | rc = filemap_write_and_wait(file->f_path.dentry->d_inode->i_mapping); |
| 225 | if (rc != 0) | 225 | if (rc != 0) |
| 226 | CIFS_I(file->f_path.dentry->d_inode)->write_behind_rc = rc; | 226 | CIFS_I(file->f_path.dentry->d_inode)->write_behind_rc = rc; |
| @@ -1890,11 +1890,10 @@ static ssize_t cifs_read(struct file *file, char *read_data, size_t read_size, | |||
| 1890 | 1890 | ||
| 1891 | int cifs_file_mmap(struct file *file, struct vm_area_struct *vma) | 1891 | int cifs_file_mmap(struct file *file, struct vm_area_struct *vma) |
| 1892 | { | 1892 | { |
| 1893 | struct dentry *dentry = file->f_path.dentry; | ||
| 1894 | int rc, xid; | 1893 | int rc, xid; |
| 1895 | 1894 | ||
| 1896 | xid = GetXid(); | 1895 | xid = GetXid(); |
| 1897 | rc = cifs_revalidate(dentry); | 1896 | rc = cifs_revalidate_file(file); |
| 1898 | if (rc) { | 1897 | if (rc) { |
| 1899 | cFYI(1, ("Validation prior to mmap failed, error=%d", rc)); | 1898 | cFYI(1, ("Validation prior to mmap failed, error=%d", rc)); |
| 1900 | FreeXid(xid); | 1899 | FreeXid(xid); |
diff --git a/fs/cifs/inode.c b/fs/cifs/inode.c index 8bdbc818164c..723daaccbd0e 100644 --- a/fs/cifs/inode.c +++ b/fs/cifs/inode.c | |||
| @@ -77,6 +77,41 @@ static void cifs_set_ops(struct inode *inode, const bool is_dfs_referral) | |||
| 77 | } | 77 | } |
| 78 | } | 78 | } |
| 79 | 79 | ||
| 80 | /* check inode attributes against fattr. If they don't match, tag the | ||
| 81 | * inode for cache invalidation | ||
| 82 | */ | ||
| 83 | static void | ||
| 84 | cifs_revalidate_cache(struct inode *inode, struct cifs_fattr *fattr) | ||
| 85 | { | ||
| 86 | struct cifsInodeInfo *cifs_i = CIFS_I(inode); | ||
| 87 | |||
| 88 | cFYI(1, ("%s: revalidating inode %llu", __func__, cifs_i->uniqueid)); | ||
| 89 | |||
| 90 | if (inode->i_state & I_NEW) { | ||
| 91 | cFYI(1, ("%s: inode %llu is new", __func__, cifs_i->uniqueid)); | ||
| 92 | return; | ||
| 93 | } | ||
| 94 | |||
| 95 | /* don't bother with revalidation if we have an oplock */ | ||
| 96 | if (cifs_i->clientCanCacheRead) { | ||
| 97 | cFYI(1, ("%s: inode %llu is oplocked", __func__, | ||
| 98 | cifs_i->uniqueid)); | ||
| 99 | return; | ||
| 100 | } | ||
| 101 | |||
| 102 | /* revalidate if mtime or size have changed */ | ||
| 103 | if (timespec_equal(&inode->i_mtime, &fattr->cf_mtime) && | ||
| 104 | cifs_i->server_eof == fattr->cf_eof) { | ||
| 105 | cFYI(1, ("%s: inode %llu is unchanged", __func__, | ||
| 106 | cifs_i->uniqueid)); | ||
| 107 | return; | ||
| 108 | } | ||
| 109 | |||
| 110 | cFYI(1, ("%s: invalidating inode %llu mapping", __func__, | ||
| 111 | cifs_i->uniqueid)); | ||
| 112 | cifs_i->invalid_mapping = true; | ||
| 113 | } | ||
| 114 | |||
| 80 | /* populate an inode with info from a cifs_fattr struct */ | 115 | /* populate an inode with info from a cifs_fattr struct */ |
| 81 | void | 116 | void |
| 82 | cifs_fattr_to_inode(struct inode *inode, struct cifs_fattr *fattr) | 117 | cifs_fattr_to_inode(struct inode *inode, struct cifs_fattr *fattr) |
| @@ -85,6 +120,8 @@ cifs_fattr_to_inode(struct inode *inode, struct cifs_fattr *fattr) | |||
| 85 | struct cifs_sb_info *cifs_sb = CIFS_SB(inode->i_sb); | 120 | struct cifs_sb_info *cifs_sb = CIFS_SB(inode->i_sb); |
| 86 | unsigned long oldtime = cifs_i->time; | 121 | unsigned long oldtime = cifs_i->time; |
| 87 | 122 | ||
| 123 | cifs_revalidate_cache(inode, fattr); | ||
| 124 | |||
| 88 | inode->i_atime = fattr->cf_atime; | 125 | inode->i_atime = fattr->cf_atime; |
| 89 | inode->i_mtime = fattr->cf_mtime; | 126 | inode->i_mtime = fattr->cf_mtime; |
| 90 | inode->i_ctime = fattr->cf_ctime; | 127 | inode->i_ctime = fattr->cf_ctime; |
| @@ -231,6 +268,31 @@ cifs_create_dfs_fattr(struct cifs_fattr *fattr, struct super_block *sb) | |||
| 231 | fattr->cf_flags |= CIFS_FATTR_DFS_REFERRAL; | 268 | fattr->cf_flags |= CIFS_FATTR_DFS_REFERRAL; |
| 232 | } | 269 | } |
| 233 | 270 | ||
| 271 | int cifs_get_file_info_unix(struct file *filp) | ||
| 272 | { | ||
| 273 | int rc; | ||
| 274 | int xid; | ||
| 275 | FILE_UNIX_BASIC_INFO find_data; | ||
| 276 | struct cifs_fattr fattr; | ||
| 277 | struct inode *inode = filp->f_path.dentry->d_inode; | ||
| 278 | struct cifs_sb_info *cifs_sb = CIFS_SB(inode->i_sb); | ||
| 279 | struct cifsTconInfo *tcon = cifs_sb->tcon; | ||
| 280 | struct cifsFileInfo *cfile = (struct cifsFileInfo *) filp->private_data; | ||
| 281 | |||
| 282 | xid = GetXid(); | ||
| 283 | rc = CIFSSMBUnixQFileInfo(xid, tcon, cfile->netfid, &find_data); | ||
| 284 | if (!rc) { | ||
| 285 | cifs_unix_basic_to_fattr(&fattr, &find_data, cifs_sb); | ||
| 286 | } else if (rc == -EREMOTE) { | ||
| 287 | cifs_create_dfs_fattr(&fattr, inode->i_sb); | ||
| 288 | rc = 0; | ||
| 289 | } | ||
| 290 | |||
| 291 | cifs_fattr_to_inode(inode, &fattr); | ||
| 292 | FreeXid(xid); | ||
| 293 | return rc; | ||
| 294 | } | ||
| 295 | |||
| 234 | int cifs_get_inode_info_unix(struct inode **pinode, | 296 | int cifs_get_inode_info_unix(struct inode **pinode, |
| 235 | const unsigned char *full_path, | 297 | const unsigned char *full_path, |
| 236 | struct super_block *sb, int xid) | 298 | struct super_block *sb, int xid) |
| @@ -432,6 +494,47 @@ cifs_all_info_to_fattr(struct cifs_fattr *fattr, FILE_ALL_INFO *info, | |||
| 432 | fattr->cf_gid = cifs_sb->mnt_gid; | 494 | fattr->cf_gid = cifs_sb->mnt_gid; |
| 433 | } | 495 | } |
| 434 | 496 | ||
| 497 | int cifs_get_file_info(struct file *filp) | ||
| 498 | { | ||
| 499 | int rc; | ||
| 500 | int xid; | ||
| 501 | FILE_ALL_INFO find_data; | ||
| 502 | struct cifs_fattr fattr; | ||
| 503 | struct inode *inode = filp->f_path.dentry->d_inode; | ||
| 504 | struct cifs_sb_info *cifs_sb = CIFS_SB(inode->i_sb); | ||
| 505 | struct cifsTconInfo *tcon = cifs_sb->tcon; | ||
| 506 | struct cifsFileInfo *cfile = (struct cifsFileInfo *) filp->private_data; | ||
| 507 | |||
| 508 | xid = GetXid(); | ||
| 509 | rc = CIFSSMBQFileInfo(xid, tcon, cfile->netfid, &find_data); | ||
| 510 | if (rc == -EOPNOTSUPP || rc == -EINVAL) { | ||
| 511 | /* | ||
| 512 | * FIXME: legacy server -- fall back to path-based call? | ||
| 513 | * for now, just skip revalidating and mark inode for | ||
| 514 | * immediate reval. | ||
| 515 | */ | ||
| 516 | rc = 0; | ||
| 517 | CIFS_I(inode)->time = 0; | ||
| 518 | goto cgfi_exit; | ||
| 519 | } else if (rc == -EREMOTE) { | ||
| 520 | cifs_create_dfs_fattr(&fattr, inode->i_sb); | ||
| 521 | rc = 0; | ||
| 522 | } else if (rc) | ||
| 523 | goto cgfi_exit; | ||
| 524 | |||
| 525 | /* | ||
| 526 | * don't bother with SFU junk here -- just mark inode as needing | ||
| 527 | * revalidation. | ||
| 528 | */ | ||
| 529 | cifs_all_info_to_fattr(&fattr, &find_data, cifs_sb, false); | ||
| 530 | fattr.cf_uniqueid = CIFS_I(inode)->uniqueid; | ||
| 531 | fattr.cf_flags |= CIFS_FATTR_NEED_REVAL; | ||
| 532 | cifs_fattr_to_inode(inode, &fattr); | ||
| 533 | cgfi_exit: | ||
| 534 | FreeXid(xid); | ||
| 535 | return rc; | ||
| 536 | } | ||
| 537 | |||
| 435 | int cifs_get_inode_info(struct inode **pinode, | 538 | int cifs_get_inode_info(struct inode **pinode, |
| 436 | const unsigned char *full_path, FILE_ALL_INFO *pfindData, | 539 | const unsigned char *full_path, FILE_ALL_INFO *pfindData, |
| 437 | struct super_block *sb, int xid, const __u16 *pfid) | 540 | struct super_block *sb, int xid, const __u16 *pfid) |
| @@ -1389,135 +1492,103 @@ cifs_rename_exit: | |||
| 1389 | return rc; | 1492 | return rc; |
| 1390 | } | 1493 | } |
| 1391 | 1494 | ||
| 1392 | int cifs_revalidate(struct dentry *direntry) | 1495 | static bool |
| 1496 | cifs_inode_needs_reval(struct inode *inode) | ||
| 1393 | { | 1497 | { |
| 1394 | int xid; | 1498 | struct cifsInodeInfo *cifs_i = CIFS_I(inode); |
| 1395 | int rc = 0, wbrc = 0; | ||
| 1396 | char *full_path; | ||
| 1397 | struct cifs_sb_info *cifs_sb; | ||
| 1398 | struct cifsInodeInfo *cifsInode; | ||
| 1399 | loff_t local_size; | ||
| 1400 | struct timespec local_mtime; | ||
| 1401 | bool invalidate_inode = false; | ||
| 1402 | 1499 | ||
| 1403 | if (direntry->d_inode == NULL) | 1500 | if (cifs_i->clientCanCacheRead) |
| 1404 | return -ENOENT; | 1501 | return false; |
| 1405 | 1502 | ||
| 1406 | cifsInode = CIFS_I(direntry->d_inode); | 1503 | if (!lookupCacheEnabled) |
| 1504 | return true; | ||
| 1407 | 1505 | ||
| 1408 | if (cifsInode == NULL) | 1506 | if (cifs_i->time == 0) |
| 1409 | return -ENOENT; | 1507 | return true; |
| 1410 | 1508 | ||
| 1411 | /* no sense revalidating inode info on file that no one can write */ | 1509 | /* FIXME: the actimeo should be tunable */ |
| 1412 | if (CIFS_I(direntry->d_inode)->clientCanCacheRead) | 1510 | if (time_after_eq(jiffies, cifs_i->time + HZ)) |
| 1413 | return rc; | 1511 | return true; |
| 1512 | |||
| 1513 | return false; | ||
| 1514 | } | ||
| 1515 | |||
| 1516 | /* check invalid_mapping flag and zap the cache if it's set */ | ||
| 1517 | static void | ||
| 1518 | cifs_invalidate_mapping(struct inode *inode) | ||
| 1519 | { | ||
| 1520 | int rc; | ||
| 1521 | struct cifsInodeInfo *cifs_i = CIFS_I(inode); | ||
| 1522 | |||
| 1523 | cifs_i->invalid_mapping = false; | ||
| 1524 | |||
| 1525 | /* write back any cached data */ | ||
| 1526 | if (inode->i_mapping && inode->i_mapping->nrpages != 0) { | ||
| 1527 | rc = filemap_write_and_wait(inode->i_mapping); | ||
| 1528 | if (rc) | ||
| 1529 | cifs_i->write_behind_rc = rc; | ||
| 1530 | } | ||
| 1531 | invalidate_remote_inode(inode); | ||
| 1532 | } | ||
| 1533 | |||
| 1534 | int cifs_revalidate_file(struct file *filp) | ||
| 1535 | { | ||
| 1536 | int rc = 0; | ||
| 1537 | struct inode *inode = filp->f_path.dentry->d_inode; | ||
| 1538 | |||
| 1539 | if (!cifs_inode_needs_reval(inode)) | ||
| 1540 | goto check_inval; | ||
| 1541 | |||
| 1542 | if (CIFS_SB(inode->i_sb)->tcon->unix_ext) | ||
| 1543 | rc = cifs_get_file_info_unix(filp); | ||
| 1544 | else | ||
| 1545 | rc = cifs_get_file_info(filp); | ||
| 1546 | |||
| 1547 | check_inval: | ||
| 1548 | if (CIFS_I(inode)->invalid_mapping) | ||
| 1549 | cifs_invalidate_mapping(inode); | ||
| 1550 | |||
| 1551 | return rc; | ||
| 1552 | } | ||
| 1553 | |||
| 1554 | /* revalidate a dentry's inode attributes */ | ||
| 1555 | int cifs_revalidate_dentry(struct dentry *dentry) | ||
| 1556 | { | ||
| 1557 | int xid; | ||
| 1558 | int rc = 0; | ||
| 1559 | char *full_path = NULL; | ||
| 1560 | struct inode *inode = dentry->d_inode; | ||
| 1561 | struct super_block *sb = dentry->d_sb; | ||
| 1562 | |||
| 1563 | if (inode == NULL) | ||
| 1564 | return -ENOENT; | ||
| 1414 | 1565 | ||
| 1415 | xid = GetXid(); | 1566 | xid = GetXid(); |
| 1416 | 1567 | ||
| 1417 | cifs_sb = CIFS_SB(direntry->d_sb); | 1568 | if (!cifs_inode_needs_reval(inode)) |
| 1569 | goto check_inval; | ||
| 1418 | 1570 | ||
| 1419 | /* can not safely grab the rename sem here if rename calls revalidate | 1571 | /* can not safely grab the rename sem here if rename calls revalidate |
| 1420 | since that would deadlock */ | 1572 | since that would deadlock */ |
| 1421 | full_path = build_path_from_dentry(direntry); | 1573 | full_path = build_path_from_dentry(dentry); |
| 1422 | if (full_path == NULL) { | 1574 | if (full_path == NULL) { |
| 1423 | rc = -ENOMEM; | 1575 | rc = -ENOMEM; |
| 1424 | FreeXid(xid); | 1576 | goto check_inval; |
| 1425 | return rc; | ||
| 1426 | } | ||
| 1427 | cFYI(1, ("Revalidate: %s inode 0x%p count %d dentry: 0x%p d_time %ld " | ||
| 1428 | "jiffies %ld", full_path, direntry->d_inode, | ||
| 1429 | direntry->d_inode->i_count.counter, direntry, | ||
| 1430 | direntry->d_time, jiffies)); | ||
| 1431 | |||
| 1432 | if (cifsInode->time == 0) { | ||
| 1433 | /* was set to zero previously to force revalidate */ | ||
| 1434 | } else if (time_before(jiffies, cifsInode->time + HZ) && | ||
| 1435 | lookupCacheEnabled) { | ||
| 1436 | if ((S_ISREG(direntry->d_inode->i_mode) == 0) || | ||
| 1437 | (direntry->d_inode->i_nlink == 1)) { | ||
| 1438 | kfree(full_path); | ||
| 1439 | FreeXid(xid); | ||
| 1440 | return rc; | ||
| 1441 | } else { | ||
| 1442 | cFYI(1, ("Have to revalidate file due to hardlinks")); | ||
| 1443 | } | ||
| 1444 | } | ||
| 1445 | |||
| 1446 | /* save mtime and size */ | ||
| 1447 | local_mtime = direntry->d_inode->i_mtime; | ||
| 1448 | local_size = direntry->d_inode->i_size; | ||
| 1449 | |||
| 1450 | if (cifs_sb->tcon->unix_ext) { | ||
| 1451 | rc = cifs_get_inode_info_unix(&direntry->d_inode, full_path, | ||
| 1452 | direntry->d_sb, xid); | ||
| 1453 | if (rc) { | ||
| 1454 | cFYI(1, ("error on getting revalidate info %d", rc)); | ||
| 1455 | /* if (rc != -ENOENT) | ||
| 1456 | rc = 0; */ /* BB should we cache info on | ||
| 1457 | certain errors? */ | ||
| 1458 | } | ||
| 1459 | } else { | ||
| 1460 | rc = cifs_get_inode_info(&direntry->d_inode, full_path, NULL, | ||
| 1461 | direntry->d_sb, xid, NULL); | ||
| 1462 | if (rc) { | ||
| 1463 | cFYI(1, ("error on getting revalidate info %d", rc)); | ||
| 1464 | /* if (rc != -ENOENT) | ||
| 1465 | rc = 0; */ /* BB should we cache info on | ||
| 1466 | certain errors? */ | ||
| 1467 | } | ||
| 1468 | } | 1577 | } |
| 1469 | /* should we remap certain errors, access denied?, to zero */ | ||
| 1470 | 1578 | ||
| 1471 | /* if not oplocked, we invalidate inode pages if mtime or file size | 1579 | cFYI(1, ("Revalidate: %s inode 0x%p count %d dentry: 0x%p d_time %ld " |
| 1472 | had changed on server */ | 1580 | "jiffies %ld", full_path, inode, inode->i_count.counter, |
| 1581 | dentry, dentry->d_time, jiffies)); | ||
| 1473 | 1582 | ||
| 1474 | if (timespec_equal(&local_mtime, &direntry->d_inode->i_mtime) && | 1583 | if (CIFS_SB(sb)->tcon->unix_ext) |
| 1475 | (local_size == direntry->d_inode->i_size)) { | 1584 | rc = cifs_get_inode_info_unix(&inode, full_path, sb, xid); |
| 1476 | cFYI(1, ("cifs_revalidate - inode unchanged")); | 1585 | else |
| 1477 | } else { | 1586 | rc = cifs_get_inode_info(&inode, full_path, NULL, sb, |
| 1478 | /* file may have changed on server */ | 1587 | xid, NULL); |
| 1479 | if (cifsInode->clientCanCacheRead) { | ||
| 1480 | /* no need to invalidate inode pages since we were the | ||
| 1481 | only ones who could have modified the file and the | ||
| 1482 | server copy is staler than ours */ | ||
| 1483 | } else { | ||
| 1484 | invalidate_inode = true; | ||
| 1485 | } | ||
| 1486 | } | ||
| 1487 | 1588 | ||
| 1488 | /* can not grab this sem since kernel filesys locking documentation | 1589 | check_inval: |
| 1489 | indicates i_mutex may be taken by the kernel on lookup and rename | 1590 | if (CIFS_I(inode)->invalid_mapping) |
| 1490 | which could deadlock if we grab the i_mutex here as well */ | 1591 | cifs_invalidate_mapping(inode); |
| 1491 | /* mutex_lock(&direntry->d_inode->i_mutex);*/ | ||
| 1492 | /* need to write out dirty pages here */ | ||
| 1493 | if (direntry->d_inode->i_mapping) { | ||
| 1494 | /* do we need to lock inode until after invalidate completes | ||
| 1495 | below? */ | ||
| 1496 | wbrc = filemap_fdatawrite(direntry->d_inode->i_mapping); | ||
| 1497 | if (wbrc) | ||
| 1498 | CIFS_I(direntry->d_inode)->write_behind_rc = wbrc; | ||
| 1499 | } | ||
| 1500 | if (invalidate_inode) { | ||
| 1501 | /* shrink_dcache not necessary now that cifs dentry ops | ||
| 1502 | are exported for negative dentries */ | ||
| 1503 | /* if (S_ISDIR(direntry->d_inode->i_mode)) | ||
| 1504 | shrink_dcache_parent(direntry); */ | ||
| 1505 | if (S_ISREG(direntry->d_inode->i_mode)) { | ||
| 1506 | if (direntry->d_inode->i_mapping) { | ||
| 1507 | wbrc = filemap_fdatawait(direntry->d_inode->i_mapping); | ||
| 1508 | if (wbrc) | ||
| 1509 | CIFS_I(direntry->d_inode)->write_behind_rc = wbrc; | ||
| 1510 | } | ||
| 1511 | /* may eventually have to do this for open files too */ | ||
| 1512 | if (list_empty(&(cifsInode->openFileList))) { | ||
| 1513 | /* changed on server - flush read ahead pages */ | ||
| 1514 | cFYI(1, ("Invalidating read ahead data on " | ||
| 1515 | "closed file")); | ||
| 1516 | invalidate_remote_inode(direntry->d_inode); | ||
| 1517 | } | ||
| 1518 | } | ||
| 1519 | } | ||
| 1520 | /* mutex_unlock(&direntry->d_inode->i_mutex); */ | ||
| 1521 | 1592 | ||
| 1522 | kfree(full_path); | 1593 | kfree(full_path); |
| 1523 | FreeXid(xid); | 1594 | FreeXid(xid); |
| @@ -1527,7 +1598,7 @@ int cifs_revalidate(struct dentry *direntry) | |||
| 1527 | int cifs_getattr(struct vfsmount *mnt, struct dentry *dentry, | 1598 | int cifs_getattr(struct vfsmount *mnt, struct dentry *dentry, |
| 1528 | struct kstat *stat) | 1599 | struct kstat *stat) |
| 1529 | { | 1600 | { |
| 1530 | int err = cifs_revalidate(dentry); | 1601 | int err = cifs_revalidate_dentry(dentry); |
| 1531 | if (!err) { | 1602 | if (!err) { |
| 1532 | generic_fillattr(dentry->d_inode, stat); | 1603 | generic_fillattr(dentry->d_inode, stat); |
| 1533 | stat->blksize = CIFS_MAX_MSGSIZE; | 1604 | stat->blksize = CIFS_MAX_MSGSIZE; |
