diff options
Diffstat (limited to 'fs')
39 files changed, 489 insertions, 736 deletions
diff --git a/fs/binfmt_flat.c b/fs/binfmt_flat.c index b6ab27ccf214..811384bec8de 100644 --- a/fs/binfmt_flat.c +++ b/fs/binfmt_flat.c | |||
| @@ -68,11 +68,7 @@ | |||
| 68 | * Here we can be a bit looser than the data sections since this | 68 | * Here we can be a bit looser than the data sections since this |
| 69 | * needs to only meet arch ABI requirements. | 69 | * needs to only meet arch ABI requirements. |
| 70 | */ | 70 | */ |
| 71 | #ifdef ARCH_SLAB_MINALIGN | 71 | #define FLAT_STACK_ALIGN max_t(unsigned long, sizeof(void *), ARCH_SLAB_MINALIGN) |
| 72 | #define FLAT_STACK_ALIGN (ARCH_SLAB_MINALIGN) | ||
| 73 | #else | ||
| 74 | #define FLAT_STACK_ALIGN (sizeof(void *)) | ||
| 75 | #endif | ||
| 76 | 72 | ||
| 77 | #define RELOC_FAILED 0xff00ff01 /* Relocation incorrect somewhere */ | 73 | #define RELOC_FAILED 0xff00ff01 /* Relocation incorrect somewhere */ |
| 78 | #define UNLOADED_LIB 0x7ff000ff /* Placeholder for unused library */ | 74 | #define UNLOADED_LIB 0x7ff000ff /* Placeholder for unused library */ |
diff --git a/fs/cifs/cifsfs.c b/fs/cifs/cifsfs.c index 78c02eb4cb1f..484e52bb40bb 100644 --- a/fs/cifs/cifsfs.c +++ b/fs/cifs/cifsfs.c | |||
| @@ -473,14 +473,24 @@ static int cifs_remount(struct super_block *sb, int *flags, char *data) | |||
| 473 | return 0; | 473 | return 0; |
| 474 | } | 474 | } |
| 475 | 475 | ||
| 476 | void cifs_drop_inode(struct inode *inode) | ||
| 477 | { | ||
| 478 | struct cifs_sb_info *cifs_sb = CIFS_SB(inode->i_sb); | ||
| 479 | |||
| 480 | if (cifs_sb->mnt_cifs_flags & CIFS_MOUNT_SERVER_INUM) | ||
| 481 | return generic_drop_inode(inode); | ||
| 482 | |||
| 483 | return generic_delete_inode(inode); | ||
| 484 | } | ||
| 485 | |||
| 476 | static const struct super_operations cifs_super_ops = { | 486 | static const struct super_operations cifs_super_ops = { |
| 477 | .put_super = cifs_put_super, | 487 | .put_super = cifs_put_super, |
| 478 | .statfs = cifs_statfs, | 488 | .statfs = cifs_statfs, |
| 479 | .alloc_inode = cifs_alloc_inode, | 489 | .alloc_inode = cifs_alloc_inode, |
| 480 | .destroy_inode = cifs_destroy_inode, | 490 | .destroy_inode = cifs_destroy_inode, |
| 481 | /* .drop_inode = generic_delete_inode, | 491 | .drop_inode = cifs_drop_inode, |
| 482 | .delete_inode = cifs_delete_inode, */ /* Do not need above two | 492 | /* .delete_inode = cifs_delete_inode, */ /* Do not need above |
| 483 | functions unless later we add lazy close of inodes or unless the | 493 | function unless later we add lazy close of inodes or unless the |
| 484 | kernel forgets to call us with the same number of releases (closes) | 494 | kernel forgets to call us with the same number of releases (closes) |
| 485 | as opens */ | 495 | as opens */ |
| 486 | .show_options = cifs_show_options, | 496 | .show_options = cifs_show_options, |
diff --git a/fs/cifs/cifsproto.h b/fs/cifs/cifsproto.h index fb1657e0fdb8..fb6318b81509 100644 --- a/fs/cifs/cifsproto.h +++ b/fs/cifs/cifsproto.h | |||
| @@ -106,7 +106,6 @@ extern struct cifsFileInfo *cifs_new_fileinfo(struct inode *newinode, | |||
| 106 | __u16 fileHandle, struct file *file, | 106 | __u16 fileHandle, struct file *file, |
| 107 | struct vfsmount *mnt, unsigned int oflags); | 107 | struct vfsmount *mnt, unsigned int oflags); |
| 108 | extern int cifs_posix_open(char *full_path, struct inode **pinode, | 108 | extern int cifs_posix_open(char *full_path, struct inode **pinode, |
| 109 | struct vfsmount *mnt, | ||
| 110 | struct super_block *sb, | 109 | struct super_block *sb, |
| 111 | int mode, int oflags, | 110 | int mode, int oflags, |
| 112 | __u32 *poplock, __u16 *pnetfid, int xid); | 111 | __u32 *poplock, __u16 *pnetfid, int xid); |
diff --git a/fs/cifs/dir.c b/fs/cifs/dir.c index 391816b461ca..e7ae78b66fa1 100644 --- a/fs/cifs/dir.c +++ b/fs/cifs/dir.c | |||
| @@ -25,6 +25,7 @@ | |||
| 25 | #include <linux/slab.h> | 25 | #include <linux/slab.h> |
| 26 | #include <linux/namei.h> | 26 | #include <linux/namei.h> |
| 27 | #include <linux/mount.h> | 27 | #include <linux/mount.h> |
| 28 | #include <linux/file.h> | ||
| 28 | #include "cifsfs.h" | 29 | #include "cifsfs.h" |
| 29 | #include "cifspdu.h" | 30 | #include "cifspdu.h" |
| 30 | #include "cifsglob.h" | 31 | #include "cifsglob.h" |
| @@ -184,12 +185,13 @@ cifs_new_fileinfo(struct inode *newinode, __u16 fileHandle, | |||
| 184 | } | 185 | } |
| 185 | write_unlock(&GlobalSMBSeslock); | 186 | write_unlock(&GlobalSMBSeslock); |
| 186 | 187 | ||
| 188 | file->private_data = pCifsFile; | ||
| 189 | |||
| 187 | return pCifsFile; | 190 | return pCifsFile; |
| 188 | } | 191 | } |
| 189 | 192 | ||
| 190 | int cifs_posix_open(char *full_path, struct inode **pinode, | 193 | int cifs_posix_open(char *full_path, struct inode **pinode, |
| 191 | struct vfsmount *mnt, struct super_block *sb, | 194 | struct super_block *sb, int mode, int oflags, |
| 192 | int mode, int oflags, | ||
| 193 | __u32 *poplock, __u16 *pnetfid, int xid) | 195 | __u32 *poplock, __u16 *pnetfid, int xid) |
| 194 | { | 196 | { |
| 195 | int rc; | 197 | int rc; |
| @@ -258,19 +260,6 @@ int cifs_posix_open(char *full_path, struct inode **pinode, | |||
| 258 | cifs_fattr_to_inode(*pinode, &fattr); | 260 | cifs_fattr_to_inode(*pinode, &fattr); |
| 259 | } | 261 | } |
| 260 | 262 | ||
| 261 | /* | ||
| 262 | * cifs_fill_filedata() takes care of setting cifsFileInfo pointer to | ||
| 263 | * file->private_data. | ||
| 264 | */ | ||
| 265 | if (mnt) { | ||
| 266 | struct cifsFileInfo *pfile_info; | ||
| 267 | |||
| 268 | pfile_info = cifs_new_fileinfo(*pinode, *pnetfid, NULL, mnt, | ||
| 269 | oflags); | ||
| 270 | if (pfile_info == NULL) | ||
| 271 | rc = -ENOMEM; | ||
| 272 | } | ||
| 273 | |||
| 274 | posix_open_ret: | 263 | posix_open_ret: |
| 275 | kfree(presp_data); | 264 | kfree(presp_data); |
| 276 | return rc; | 265 | return rc; |
| @@ -298,7 +287,6 @@ cifs_create(struct inode *inode, struct dentry *direntry, int mode, | |||
| 298 | int create_options = CREATE_NOT_DIR; | 287 | int create_options = CREATE_NOT_DIR; |
| 299 | __u32 oplock = 0; | 288 | __u32 oplock = 0; |
| 300 | int oflags; | 289 | int oflags; |
| 301 | bool posix_create = false; | ||
| 302 | /* | 290 | /* |
| 303 | * BB below access is probably too much for mknod to request | 291 | * BB below access is probably too much for mknod to request |
| 304 | * but we have to do query and setpathinfo so requesting | 292 | * but we have to do query and setpathinfo so requesting |
| @@ -339,7 +327,6 @@ cifs_create(struct inode *inode, struct dentry *direntry, int mode, | |||
| 339 | (CIFS_UNIX_POSIX_PATH_OPS_CAP & | 327 | (CIFS_UNIX_POSIX_PATH_OPS_CAP & |
| 340 | le64_to_cpu(tcon->fsUnixInfo.Capability))) { | 328 | le64_to_cpu(tcon->fsUnixInfo.Capability))) { |
| 341 | rc = cifs_posix_open(full_path, &newinode, | 329 | rc = cifs_posix_open(full_path, &newinode, |
| 342 | nd ? nd->path.mnt : NULL, | ||
| 343 | inode->i_sb, mode, oflags, &oplock, &fileHandle, xid); | 330 | inode->i_sb, mode, oflags, &oplock, &fileHandle, xid); |
| 344 | /* EIO could indicate that (posix open) operation is not | 331 | /* EIO could indicate that (posix open) operation is not |
| 345 | supported, despite what server claimed in capability | 332 | supported, despite what server claimed in capability |
| @@ -347,7 +334,6 @@ cifs_create(struct inode *inode, struct dentry *direntry, int mode, | |||
| 347 | handled in posix open */ | 334 | handled in posix open */ |
| 348 | 335 | ||
| 349 | if (rc == 0) { | 336 | if (rc == 0) { |
| 350 | posix_create = true; | ||
| 351 | if (newinode == NULL) /* query inode info */ | 337 | if (newinode == NULL) /* query inode info */ |
| 352 | goto cifs_create_get_file_info; | 338 | goto cifs_create_get_file_info; |
| 353 | else /* success, no need to query */ | 339 | else /* success, no need to query */ |
| @@ -478,21 +464,28 @@ cifs_create_set_dentry: | |||
| 478 | else | 464 | else |
| 479 | cFYI(1, "Create worked, get_inode_info failed rc = %d", rc); | 465 | cFYI(1, "Create worked, get_inode_info failed rc = %d", rc); |
| 480 | 466 | ||
| 481 | /* nfsd case - nfs srv does not set nd */ | 467 | if (newinode && nd && (nd->flags & LOOKUP_OPEN)) { |
| 482 | if ((nd == NULL) || (!(nd->flags & LOOKUP_OPEN))) { | ||
| 483 | /* mknod case - do not leave file open */ | ||
| 484 | CIFSSMBClose(xid, tcon, fileHandle); | ||
| 485 | } else if (!(posix_create) && (newinode)) { | ||
| 486 | struct cifsFileInfo *pfile_info; | 468 | struct cifsFileInfo *pfile_info; |
| 487 | /* | 469 | struct file *filp; |
| 488 | * cifs_fill_filedata() takes care of setting cifsFileInfo | 470 | |
| 489 | * pointer to file->private_data. | 471 | filp = lookup_instantiate_filp(nd, direntry, generic_file_open); |
| 490 | */ | 472 | if (IS_ERR(filp)) { |
| 491 | pfile_info = cifs_new_fileinfo(newinode, fileHandle, NULL, | 473 | rc = PTR_ERR(filp); |
| 474 | CIFSSMBClose(xid, tcon, fileHandle); | ||
| 475 | goto cifs_create_out; | ||
| 476 | } | ||
| 477 | |||
| 478 | pfile_info = cifs_new_fileinfo(newinode, fileHandle, filp, | ||
| 492 | nd->path.mnt, oflags); | 479 | nd->path.mnt, oflags); |
| 493 | if (pfile_info == NULL) | 480 | if (pfile_info == NULL) { |
| 481 | fput(filp); | ||
| 482 | CIFSSMBClose(xid, tcon, fileHandle); | ||
| 494 | rc = -ENOMEM; | 483 | rc = -ENOMEM; |
| 484 | } | ||
| 485 | } else { | ||
| 486 | CIFSSMBClose(xid, tcon, fileHandle); | ||
| 495 | } | 487 | } |
| 488 | |||
| 496 | cifs_create_out: | 489 | cifs_create_out: |
| 497 | kfree(buf); | 490 | kfree(buf); |
| 498 | kfree(full_path); | 491 | kfree(full_path); |
| @@ -636,6 +629,7 @@ cifs_lookup(struct inode *parent_dir_inode, struct dentry *direntry, | |||
| 636 | bool posix_open = false; | 629 | bool posix_open = false; |
| 637 | struct cifs_sb_info *cifs_sb; | 630 | struct cifs_sb_info *cifs_sb; |
| 638 | struct cifsTconInfo *pTcon; | 631 | struct cifsTconInfo *pTcon; |
| 632 | struct cifsFileInfo *cfile; | ||
| 639 | struct inode *newInode = NULL; | 633 | struct inode *newInode = NULL; |
| 640 | char *full_path = NULL; | 634 | char *full_path = NULL; |
| 641 | struct file *filp; | 635 | struct file *filp; |
| @@ -703,7 +697,7 @@ cifs_lookup(struct inode *parent_dir_inode, struct dentry *direntry, | |||
| 703 | if (nd && !(nd->flags & (LOOKUP_PARENT | LOOKUP_DIRECTORY)) && | 697 | if (nd && !(nd->flags & (LOOKUP_PARENT | LOOKUP_DIRECTORY)) && |
| 704 | (nd->flags & LOOKUP_OPEN) && !pTcon->broken_posix_open && | 698 | (nd->flags & LOOKUP_OPEN) && !pTcon->broken_posix_open && |
| 705 | (nd->intent.open.flags & O_CREAT)) { | 699 | (nd->intent.open.flags & O_CREAT)) { |
| 706 | rc = cifs_posix_open(full_path, &newInode, nd->path.mnt, | 700 | rc = cifs_posix_open(full_path, &newInode, |
| 707 | parent_dir_inode->i_sb, | 701 | parent_dir_inode->i_sb, |
| 708 | nd->intent.open.create_mode, | 702 | nd->intent.open.create_mode, |
| 709 | nd->intent.open.flags, &oplock, | 703 | nd->intent.open.flags, &oplock, |
| @@ -733,8 +727,25 @@ cifs_lookup(struct inode *parent_dir_inode, struct dentry *direntry, | |||
| 733 | else | 727 | else |
| 734 | direntry->d_op = &cifs_dentry_ops; | 728 | direntry->d_op = &cifs_dentry_ops; |
| 735 | d_add(direntry, newInode); | 729 | d_add(direntry, newInode); |
| 736 | if (posix_open) | 730 | if (posix_open) { |
| 737 | filp = lookup_instantiate_filp(nd, direntry, NULL); | 731 | filp = lookup_instantiate_filp(nd, direntry, |
| 732 | generic_file_open); | ||
| 733 | if (IS_ERR(filp)) { | ||
| 734 | rc = PTR_ERR(filp); | ||
| 735 | CIFSSMBClose(xid, pTcon, fileHandle); | ||
| 736 | goto lookup_out; | ||
| 737 | } | ||
| 738 | |||
| 739 | cfile = cifs_new_fileinfo(newInode, fileHandle, filp, | ||
| 740 | nd->path.mnt, | ||
| 741 | nd->intent.open.flags); | ||
| 742 | if (cfile == NULL) { | ||
| 743 | fput(filp); | ||
| 744 | CIFSSMBClose(xid, pTcon, fileHandle); | ||
| 745 | rc = -ENOMEM; | ||
| 746 | goto lookup_out; | ||
| 747 | } | ||
| 748 | } | ||
| 738 | /* since paths are not looked up by component - the parent | 749 | /* since paths are not looked up by component - the parent |
| 739 | directories are presumed to be good here */ | 750 | directories are presumed to be good here */ |
| 740 | renew_parental_timestamps(direntry); | 751 | renew_parental_timestamps(direntry); |
| @@ -755,6 +766,7 @@ cifs_lookup(struct inode *parent_dir_inode, struct dentry *direntry, | |||
| 755 | is a common return code */ | 766 | is a common return code */ |
| 756 | } | 767 | } |
| 757 | 768 | ||
| 769 | lookup_out: | ||
| 758 | kfree(full_path); | 770 | kfree(full_path); |
| 759 | FreeXid(xid); | 771 | FreeXid(xid); |
| 760 | return ERR_PTR(rc); | 772 | return ERR_PTR(rc); |
diff --git a/fs/cifs/file.c b/fs/cifs/file.c index 75541af4b3db..409e4f523e61 100644 --- a/fs/cifs/file.c +++ b/fs/cifs/file.c | |||
| @@ -162,44 +162,12 @@ psx_client_can_cache: | |||
| 162 | return 0; | 162 | return 0; |
| 163 | } | 163 | } |
| 164 | 164 | ||
| 165 | static struct cifsFileInfo * | ||
| 166 | cifs_fill_filedata(struct file *file) | ||
| 167 | { | ||
| 168 | struct list_head *tmp; | ||
| 169 | struct cifsFileInfo *pCifsFile = NULL; | ||
| 170 | struct cifsInodeInfo *pCifsInode = NULL; | ||
| 171 | |||
| 172 | /* search inode for this file and fill in file->private_data */ | ||
| 173 | pCifsInode = CIFS_I(file->f_path.dentry->d_inode); | ||
| 174 | read_lock(&GlobalSMBSeslock); | ||
| 175 | list_for_each(tmp, &pCifsInode->openFileList) { | ||
| 176 | pCifsFile = list_entry(tmp, struct cifsFileInfo, flist); | ||
| 177 | if ((pCifsFile->pfile == NULL) && | ||
| 178 | (pCifsFile->pid == current->tgid)) { | ||
| 179 | /* mode set in cifs_create */ | ||
| 180 | |||
| 181 | /* needed for writepage */ | ||
| 182 | pCifsFile->pfile = file; | ||
| 183 | file->private_data = pCifsFile; | ||
| 184 | break; | ||
| 185 | } | ||
| 186 | } | ||
| 187 | read_unlock(&GlobalSMBSeslock); | ||
| 188 | |||
| 189 | if (file->private_data != NULL) { | ||
| 190 | return pCifsFile; | ||
| 191 | } else if ((file->f_flags & O_CREAT) && (file->f_flags & O_EXCL)) | ||
| 192 | cERROR(1, "could not find file instance for " | ||
| 193 | "new file %p", file); | ||
| 194 | return NULL; | ||
| 195 | } | ||
| 196 | |||
| 197 | /* all arguments to this function must be checked for validity in caller */ | 165 | /* all arguments to this function must be checked for validity in caller */ |
| 198 | static inline int cifs_open_inode_helper(struct inode *inode, struct file *file, | 166 | static inline int cifs_open_inode_helper(struct inode *inode, |
| 199 | struct cifsInodeInfo *pCifsInode, struct cifsFileInfo *pCifsFile, | ||
| 200 | struct cifsTconInfo *pTcon, int *oplock, FILE_ALL_INFO *buf, | 167 | struct cifsTconInfo *pTcon, int *oplock, FILE_ALL_INFO *buf, |
| 201 | char *full_path, int xid) | 168 | char *full_path, int xid) |
| 202 | { | 169 | { |
| 170 | struct cifsInodeInfo *pCifsInode = CIFS_I(inode); | ||
| 203 | struct timespec temp; | 171 | struct timespec temp; |
| 204 | int rc; | 172 | int rc; |
| 205 | 173 | ||
| @@ -213,36 +181,35 @@ static inline int cifs_open_inode_helper(struct inode *inode, struct file *file, | |||
| 213 | /* if not oplocked, invalidate inode pages if mtime or file | 181 | /* if not oplocked, invalidate inode pages if mtime or file |
| 214 | size changed */ | 182 | size changed */ |
| 215 | temp = cifs_NTtimeToUnix(buf->LastWriteTime); | 183 | temp = cifs_NTtimeToUnix(buf->LastWriteTime); |
| 216 | if (timespec_equal(&file->f_path.dentry->d_inode->i_mtime, &temp) && | 184 | if (timespec_equal(&inode->i_mtime, &temp) && |
| 217 | (file->f_path.dentry->d_inode->i_size == | 185 | (inode->i_size == |
| 218 | (loff_t)le64_to_cpu(buf->EndOfFile))) { | 186 | (loff_t)le64_to_cpu(buf->EndOfFile))) { |
| 219 | cFYI(1, "inode unchanged on server"); | 187 | cFYI(1, "inode unchanged on server"); |
| 220 | } else { | 188 | } else { |
| 221 | if (file->f_path.dentry->d_inode->i_mapping) { | 189 | if (inode->i_mapping) { |
| 222 | /* BB no need to lock inode until after invalidate | 190 | /* BB no need to lock inode until after invalidate |
| 223 | since namei code should already have it locked? */ | 191 | since namei code should already have it locked? */ |
| 224 | rc = filemap_write_and_wait(file->f_path.dentry->d_inode->i_mapping); | 192 | rc = filemap_write_and_wait(inode->i_mapping); |
| 225 | if (rc != 0) | 193 | if (rc != 0) |
| 226 | CIFS_I(file->f_path.dentry->d_inode)->write_behind_rc = rc; | 194 | pCifsInode->write_behind_rc = rc; |
| 227 | } | 195 | } |
| 228 | cFYI(1, "invalidating remote inode since open detected it " | 196 | cFYI(1, "invalidating remote inode since open detected it " |
| 229 | "changed"); | 197 | "changed"); |
| 230 | invalidate_remote_inode(file->f_path.dentry->d_inode); | 198 | invalidate_remote_inode(inode); |
| 231 | } | 199 | } |
| 232 | 200 | ||
| 233 | client_can_cache: | 201 | client_can_cache: |
| 234 | if (pTcon->unix_ext) | 202 | if (pTcon->unix_ext) |
| 235 | rc = cifs_get_inode_info_unix(&file->f_path.dentry->d_inode, | 203 | rc = cifs_get_inode_info_unix(&inode, full_path, inode->i_sb, |
| 236 | full_path, inode->i_sb, xid); | 204 | xid); |
| 237 | else | 205 | else |
| 238 | rc = cifs_get_inode_info(&file->f_path.dentry->d_inode, | 206 | rc = cifs_get_inode_info(&inode, full_path, buf, inode->i_sb, |
| 239 | full_path, buf, inode->i_sb, xid, NULL); | 207 | xid, NULL); |
| 240 | 208 | ||
| 241 | if ((*oplock & 0xF) == OPLOCK_EXCLUSIVE) { | 209 | if ((*oplock & 0xF) == OPLOCK_EXCLUSIVE) { |
| 242 | pCifsInode->clientCanCacheAll = true; | 210 | pCifsInode->clientCanCacheAll = true; |
| 243 | pCifsInode->clientCanCacheRead = true; | 211 | pCifsInode->clientCanCacheRead = true; |
| 244 | cFYI(1, "Exclusive Oplock granted on inode %p", | 212 | cFYI(1, "Exclusive Oplock granted on inode %p", inode); |
| 245 | file->f_path.dentry->d_inode); | ||
| 246 | } else if ((*oplock & 0xF) == OPLOCK_READ) | 213 | } else if ((*oplock & 0xF) == OPLOCK_READ) |
| 247 | pCifsInode->clientCanCacheRead = true; | 214 | pCifsInode->clientCanCacheRead = true; |
| 248 | 215 | ||
| @@ -256,7 +223,7 @@ int cifs_open(struct inode *inode, struct file *file) | |||
| 256 | __u32 oplock; | 223 | __u32 oplock; |
| 257 | struct cifs_sb_info *cifs_sb; | 224 | struct cifs_sb_info *cifs_sb; |
| 258 | struct cifsTconInfo *tcon; | 225 | struct cifsTconInfo *tcon; |
| 259 | struct cifsFileInfo *pCifsFile; | 226 | struct cifsFileInfo *pCifsFile = NULL; |
| 260 | struct cifsInodeInfo *pCifsInode; | 227 | struct cifsInodeInfo *pCifsInode; |
| 261 | char *full_path = NULL; | 228 | char *full_path = NULL; |
| 262 | int desiredAccess; | 229 | int desiredAccess; |
| @@ -270,12 +237,6 @@ int cifs_open(struct inode *inode, struct file *file) | |||
| 270 | tcon = cifs_sb->tcon; | 237 | tcon = cifs_sb->tcon; |
| 271 | 238 | ||
| 272 | pCifsInode = CIFS_I(file->f_path.dentry->d_inode); | 239 | pCifsInode = CIFS_I(file->f_path.dentry->d_inode); |
| 273 | pCifsFile = cifs_fill_filedata(file); | ||
| 274 | if (pCifsFile) { | ||
| 275 | rc = 0; | ||
| 276 | FreeXid(xid); | ||
| 277 | return rc; | ||
| 278 | } | ||
| 279 | 240 | ||
| 280 | full_path = build_path_from_dentry(file->f_path.dentry); | 241 | full_path = build_path_from_dentry(file->f_path.dentry); |
| 281 | if (full_path == NULL) { | 242 | if (full_path == NULL) { |
| @@ -299,8 +260,7 @@ int cifs_open(struct inode *inode, struct file *file) | |||
| 299 | int oflags = (int) cifs_posix_convert_flags(file->f_flags); | 260 | int oflags = (int) cifs_posix_convert_flags(file->f_flags); |
| 300 | oflags |= SMB_O_CREAT; | 261 | oflags |= SMB_O_CREAT; |
| 301 | /* can not refresh inode info since size could be stale */ | 262 | /* can not refresh inode info since size could be stale */ |
| 302 | rc = cifs_posix_open(full_path, &inode, file->f_path.mnt, | 263 | rc = cifs_posix_open(full_path, &inode, inode->i_sb, |
| 303 | inode->i_sb, | ||
| 304 | cifs_sb->mnt_file_mode /* ignored */, | 264 | cifs_sb->mnt_file_mode /* ignored */, |
| 305 | oflags, &oplock, &netfid, xid); | 265 | oflags, &oplock, &netfid, xid); |
| 306 | if (rc == 0) { | 266 | if (rc == 0) { |
| @@ -308,9 +268,20 @@ int cifs_open(struct inode *inode, struct file *file) | |||
| 308 | /* no need for special case handling of setting mode | 268 | /* no need for special case handling of setting mode |
| 309 | on read only files needed here */ | 269 | on read only files needed here */ |
| 310 | 270 | ||
| 311 | pCifsFile = cifs_fill_filedata(file); | 271 | rc = cifs_posix_open_inode_helper(inode, file, |
| 312 | cifs_posix_open_inode_helper(inode, file, pCifsInode, | 272 | pCifsInode, oplock, netfid); |
| 313 | oplock, netfid); | 273 | if (rc != 0) { |
| 274 | CIFSSMBClose(xid, tcon, netfid); | ||
| 275 | goto out; | ||
| 276 | } | ||
| 277 | |||
| 278 | pCifsFile = cifs_new_fileinfo(inode, netfid, file, | ||
| 279 | file->f_path.mnt, | ||
| 280 | oflags); | ||
| 281 | if (pCifsFile == NULL) { | ||
| 282 | CIFSSMBClose(xid, tcon, netfid); | ||
| 283 | rc = -ENOMEM; | ||
| 284 | } | ||
| 314 | goto out; | 285 | goto out; |
| 315 | } else if ((rc == -EINVAL) || (rc == -EOPNOTSUPP)) { | 286 | } else if ((rc == -EINVAL) || (rc == -EOPNOTSUPP)) { |
| 316 | if (tcon->ses->serverNOS) | 287 | if (tcon->ses->serverNOS) |
| @@ -391,17 +362,17 @@ int cifs_open(struct inode *inode, struct file *file) | |||
| 391 | goto out; | 362 | goto out; |
| 392 | } | 363 | } |
| 393 | 364 | ||
| 365 | rc = cifs_open_inode_helper(inode, tcon, &oplock, buf, full_path, xid); | ||
| 366 | if (rc != 0) | ||
| 367 | goto out; | ||
| 368 | |||
| 394 | pCifsFile = cifs_new_fileinfo(inode, netfid, file, file->f_path.mnt, | 369 | pCifsFile = cifs_new_fileinfo(inode, netfid, file, file->f_path.mnt, |
| 395 | file->f_flags); | 370 | file->f_flags); |
| 396 | file->private_data = pCifsFile; | 371 | if (pCifsFile == NULL) { |
| 397 | if (file->private_data == NULL) { | ||
| 398 | rc = -ENOMEM; | 372 | rc = -ENOMEM; |
| 399 | goto out; | 373 | goto out; |
| 400 | } | 374 | } |
| 401 | 375 | ||
| 402 | rc = cifs_open_inode_helper(inode, file, pCifsInode, pCifsFile, tcon, | ||
| 403 | &oplock, buf, full_path, xid); | ||
| 404 | |||
| 405 | if (oplock & CIFS_CREATE_ACTION) { | 376 | if (oplock & CIFS_CREATE_ACTION) { |
| 406 | /* time to set mode which we can not set earlier due to | 377 | /* time to set mode which we can not set earlier due to |
| 407 | problems creating new read-only files */ | 378 | problems creating new read-only files */ |
| @@ -513,8 +484,7 @@ reopen_error_exit: | |||
| 513 | le64_to_cpu(tcon->fsUnixInfo.Capability))) { | 484 | le64_to_cpu(tcon->fsUnixInfo.Capability))) { |
| 514 | int oflags = (int) cifs_posix_convert_flags(file->f_flags); | 485 | int oflags = (int) cifs_posix_convert_flags(file->f_flags); |
| 515 | /* can not refresh inode info since size could be stale */ | 486 | /* can not refresh inode info since size could be stale */ |
| 516 | rc = cifs_posix_open(full_path, NULL, file->f_path.mnt, | 487 | rc = cifs_posix_open(full_path, NULL, inode->i_sb, |
| 517 | inode->i_sb, | ||
| 518 | cifs_sb->mnt_file_mode /* ignored */, | 488 | cifs_sb->mnt_file_mode /* ignored */, |
| 519 | oflags, &oplock, &netfid, xid); | 489 | oflags, &oplock, &netfid, xid); |
| 520 | if (rc == 0) { | 490 | if (rc == 0) { |
diff --git a/fs/cifs/inode.c b/fs/cifs/inode.c index 62b324f26a56..6f0683c68952 100644 --- a/fs/cifs/inode.c +++ b/fs/cifs/inode.c | |||
| @@ -1401,6 +1401,10 @@ cifs_do_rename(int xid, struct dentry *from_dentry, const char *fromPath, | |||
| 1401 | if (rc == 0 || rc != -ETXTBSY) | 1401 | if (rc == 0 || rc != -ETXTBSY) |
| 1402 | return rc; | 1402 | return rc; |
| 1403 | 1403 | ||
| 1404 | /* open-file renames don't work across directories */ | ||
| 1405 | if (to_dentry->d_parent != from_dentry->d_parent) | ||
| 1406 | return rc; | ||
| 1407 | |||
| 1404 | /* open the file to be renamed -- we need DELETE perms */ | 1408 | /* open the file to be renamed -- we need DELETE perms */ |
| 1405 | rc = CIFSSMBOpen(xid, pTcon, fromPath, FILE_OPEN, DELETE, | 1409 | rc = CIFSSMBOpen(xid, pTcon, fromPath, FILE_OPEN, DELETE, |
| 1406 | CREATE_NOT_DIR, &srcfid, &oplock, NULL, | 1410 | CREATE_NOT_DIR, &srcfid, &oplock, NULL, |
diff --git a/fs/cifs/sess.c b/fs/cifs/sess.c index 7707389bdf2c..0a57cb7db5dd 100644 --- a/fs/cifs/sess.c +++ b/fs/cifs/sess.c | |||
| @@ -730,15 +730,7 @@ ssetup_ntlmssp_authenticate: | |||
| 730 | 730 | ||
| 731 | /* calculate session key */ | 731 | /* calculate session key */ |
| 732 | setup_ntlmv2_rsp(ses, v2_sess_key, nls_cp); | 732 | setup_ntlmv2_rsp(ses, v2_sess_key, nls_cp); |
| 733 | if (first_time) /* should this be moved into common code | 733 | /* FIXME: calculate MAC key */ |
| 734 | with similar ntlmv2 path? */ | ||
| 735 | /* cifs_calculate_ntlmv2_mac_key(ses->server->mac_signing_key, | ||
| 736 | response BB FIXME, v2_sess_key); */ | ||
| 737 | |||
| 738 | /* copy session key */ | ||
| 739 | |||
| 740 | /* memcpy(bcc_ptr, (char *)ntlm_session_key,LM2_SESS_KEY_SIZE); | ||
| 741 | bcc_ptr += LM2_SESS_KEY_SIZE; */ | ||
| 742 | memcpy(bcc_ptr, (char *)v2_sess_key, | 734 | memcpy(bcc_ptr, (char *)v2_sess_key, |
| 743 | sizeof(struct ntlmv2_resp)); | 735 | sizeof(struct ntlmv2_resp)); |
| 744 | bcc_ptr += sizeof(struct ntlmv2_resp); | 736 | bcc_ptr += sizeof(struct ntlmv2_resp); |
diff --git a/fs/dcache.c b/fs/dcache.c index d96047b4a633..c8c78ba07827 100644 --- a/fs/dcache.c +++ b/fs/dcache.c | |||
| @@ -590,6 +590,8 @@ static void prune_dcache(int count) | |||
| 590 | up_read(&sb->s_umount); | 590 | up_read(&sb->s_umount); |
| 591 | } | 591 | } |
| 592 | spin_lock(&sb_lock); | 592 | spin_lock(&sb_lock); |
| 593 | /* lock was dropped, must reset next */ | ||
| 594 | list_safe_reset_next(sb, n, s_list); | ||
| 593 | count -= pruned; | 595 | count -= pruned; |
| 594 | __put_super(sb); | 596 | __put_super(sb); |
| 595 | /* more work left to do? */ | 597 | /* more work left to do? */ |
diff --git a/fs/ext2/acl.c b/fs/ext2/acl.c index ca7e2a0ed98a..2bcc0431bada 100644 --- a/fs/ext2/acl.c +++ b/fs/ext2/acl.c | |||
| @@ -200,6 +200,7 @@ ext2_set_acl(struct inode *inode, int type, struct posix_acl *acl) | |||
| 200 | return error; | 200 | return error; |
| 201 | else { | 201 | else { |
| 202 | inode->i_mode = mode; | 202 | inode->i_mode = mode; |
| 203 | inode->i_ctime = CURRENT_TIME_SEC; | ||
| 203 | mark_inode_dirty(inode); | 204 | mark_inode_dirty(inode); |
| 204 | if (error == 0) | 205 | if (error == 0) |
| 205 | acl = NULL; | 206 | acl = NULL; |
diff --git a/fs/ext3/acl.c b/fs/ext3/acl.c index 01552abbca3c..8a11fe212183 100644 --- a/fs/ext3/acl.c +++ b/fs/ext3/acl.c | |||
| @@ -205,6 +205,7 @@ ext3_set_acl(handle_t *handle, struct inode *inode, int type, | |||
| 205 | return error; | 205 | return error; |
| 206 | else { | 206 | else { |
| 207 | inode->i_mode = mode; | 207 | inode->i_mode = mode; |
| 208 | inode->i_ctime = CURRENT_TIME_SEC; | ||
| 208 | ext3_mark_inode_dirty(handle, inode); | 209 | ext3_mark_inode_dirty(handle, inode); |
| 209 | if (error == 0) | 210 | if (error == 0) |
| 210 | acl = NULL; | 211 | acl = NULL; |
diff --git a/fs/fcntl.c b/fs/fcntl.c index 51e11bf5708f..9d175d623aab 100644 --- a/fs/fcntl.c +++ b/fs/fcntl.c | |||
| @@ -733,12 +733,14 @@ static void kill_fasync_rcu(struct fasync_struct *fa, int sig, int band) | |||
| 733 | { | 733 | { |
| 734 | while (fa) { | 734 | while (fa) { |
| 735 | struct fown_struct *fown; | 735 | struct fown_struct *fown; |
| 736 | unsigned long flags; | ||
| 737 | |||
| 736 | if (fa->magic != FASYNC_MAGIC) { | 738 | if (fa->magic != FASYNC_MAGIC) { |
| 737 | printk(KERN_ERR "kill_fasync: bad magic number in " | 739 | printk(KERN_ERR "kill_fasync: bad magic number in " |
| 738 | "fasync_struct!\n"); | 740 | "fasync_struct!\n"); |
| 739 | return; | 741 | return; |
| 740 | } | 742 | } |
| 741 | spin_lock(&fa->fa_lock); | 743 | spin_lock_irqsave(&fa->fa_lock, flags); |
| 742 | if (fa->fa_file) { | 744 | if (fa->fa_file) { |
| 743 | fown = &fa->fa_file->f_owner; | 745 | fown = &fa->fa_file->f_owner; |
| 744 | /* Don't send SIGURG to processes which have not set a | 746 | /* Don't send SIGURG to processes which have not set a |
| @@ -747,7 +749,7 @@ static void kill_fasync_rcu(struct fasync_struct *fa, int sig, int band) | |||
| 747 | if (!(sig == SIGURG && fown->signum == 0)) | 749 | if (!(sig == SIGURG && fown->signum == 0)) |
| 748 | send_sigio(fown, fa->fa_fd, band); | 750 | send_sigio(fown, fa->fa_fd, band); |
| 749 | } | 751 | } |
| 750 | spin_unlock(&fa->fa_lock); | 752 | spin_unlock_irqrestore(&fa->fa_lock, flags); |
| 751 | fa = rcu_dereference(fa->fa_next); | 753 | fa = rcu_dereference(fa->fa_next); |
| 752 | } | 754 | } |
| 753 | } | 755 | } |
diff --git a/fs/fs-writeback.c b/fs/fs-writeback.c index 1d1088f48bc2..0609607d3955 100644 --- a/fs/fs-writeback.c +++ b/fs/fs-writeback.c | |||
| @@ -63,24 +63,16 @@ struct bdi_work { | |||
| 63 | }; | 63 | }; |
| 64 | 64 | ||
| 65 | enum { | 65 | enum { |
| 66 | WS_USED_B = 0, | 66 | WS_INPROGRESS = 0, |
| 67 | WS_ONSTACK_B, | 67 | WS_ONSTACK, |
| 68 | }; | 68 | }; |
| 69 | 69 | ||
| 70 | #define WS_USED (1 << WS_USED_B) | ||
| 71 | #define WS_ONSTACK (1 << WS_ONSTACK_B) | ||
| 72 | |||
| 73 | static inline bool bdi_work_on_stack(struct bdi_work *work) | ||
| 74 | { | ||
| 75 | return test_bit(WS_ONSTACK_B, &work->state); | ||
| 76 | } | ||
| 77 | |||
| 78 | static inline void bdi_work_init(struct bdi_work *work, | 70 | static inline void bdi_work_init(struct bdi_work *work, |
| 79 | struct wb_writeback_args *args) | 71 | struct wb_writeback_args *args) |
| 80 | { | 72 | { |
| 81 | INIT_RCU_HEAD(&work->rcu_head); | 73 | INIT_RCU_HEAD(&work->rcu_head); |
| 82 | work->args = *args; | 74 | work->args = *args; |
| 83 | work->state = WS_USED; | 75 | __set_bit(WS_INPROGRESS, &work->state); |
| 84 | } | 76 | } |
| 85 | 77 | ||
| 86 | /** | 78 | /** |
| @@ -95,43 +87,16 @@ int writeback_in_progress(struct backing_dev_info *bdi) | |||
| 95 | return !list_empty(&bdi->work_list); | 87 | return !list_empty(&bdi->work_list); |
| 96 | } | 88 | } |
| 97 | 89 | ||
| 98 | static void bdi_work_clear(struct bdi_work *work) | ||
| 99 | { | ||
| 100 | clear_bit(WS_USED_B, &work->state); | ||
| 101 | smp_mb__after_clear_bit(); | ||
| 102 | /* | ||
| 103 | * work can have disappeared at this point. bit waitq functions | ||
| 104 | * should be able to tolerate this, provided bdi_sched_wait does | ||
| 105 | * not dereference it's pointer argument. | ||
| 106 | */ | ||
| 107 | wake_up_bit(&work->state, WS_USED_B); | ||
| 108 | } | ||
| 109 | |||
| 110 | static void bdi_work_free(struct rcu_head *head) | 90 | static void bdi_work_free(struct rcu_head *head) |
| 111 | { | 91 | { |
| 112 | struct bdi_work *work = container_of(head, struct bdi_work, rcu_head); | 92 | struct bdi_work *work = container_of(head, struct bdi_work, rcu_head); |
| 113 | 93 | ||
| 114 | if (!bdi_work_on_stack(work)) | 94 | clear_bit(WS_INPROGRESS, &work->state); |
| 115 | kfree(work); | 95 | smp_mb__after_clear_bit(); |
| 116 | else | 96 | wake_up_bit(&work->state, WS_INPROGRESS); |
| 117 | bdi_work_clear(work); | ||
| 118 | } | ||
| 119 | |||
| 120 | static void wb_work_complete(struct bdi_work *work) | ||
| 121 | { | ||
| 122 | const enum writeback_sync_modes sync_mode = work->args.sync_mode; | ||
| 123 | int onstack = bdi_work_on_stack(work); | ||
| 124 | 97 | ||
| 125 | /* | 98 | if (!test_bit(WS_ONSTACK, &work->state)) |
| 126 | * For allocated work, we can clear the done/seen bit right here. | 99 | kfree(work); |
| 127 | * For on-stack work, we need to postpone both the clear and free | ||
| 128 | * to after the RCU grace period, since the stack could be invalidated | ||
| 129 | * as soon as bdi_work_clear() has done the wakeup. | ||
| 130 | */ | ||
| 131 | if (!onstack) | ||
| 132 | bdi_work_clear(work); | ||
| 133 | if (sync_mode == WB_SYNC_NONE || onstack) | ||
| 134 | call_rcu(&work->rcu_head, bdi_work_free); | ||
| 135 | } | 100 | } |
| 136 | 101 | ||
| 137 | static void wb_clear_pending(struct bdi_writeback *wb, struct bdi_work *work) | 102 | static void wb_clear_pending(struct bdi_writeback *wb, struct bdi_work *work) |
| @@ -147,7 +112,7 @@ static void wb_clear_pending(struct bdi_writeback *wb, struct bdi_work *work) | |||
| 147 | list_del_rcu(&work->list); | 112 | list_del_rcu(&work->list); |
| 148 | spin_unlock(&bdi->wb_lock); | 113 | spin_unlock(&bdi->wb_lock); |
| 149 | 114 | ||
| 150 | wb_work_complete(work); | 115 | call_rcu(&work->rcu_head, bdi_work_free); |
| 151 | } | 116 | } |
| 152 | } | 117 | } |
| 153 | 118 | ||
| @@ -185,9 +150,9 @@ static void bdi_queue_work(struct backing_dev_info *bdi, struct bdi_work *work) | |||
| 185 | * Used for on-stack allocated work items. The caller needs to wait until | 150 | * Used for on-stack allocated work items. The caller needs to wait until |
| 186 | * the wb threads have acked the work before it's safe to continue. | 151 | * the wb threads have acked the work before it's safe to continue. |
| 187 | */ | 152 | */ |
| 188 | static void bdi_wait_on_work_clear(struct bdi_work *work) | 153 | static void bdi_wait_on_work_done(struct bdi_work *work) |
| 189 | { | 154 | { |
| 190 | wait_on_bit(&work->state, WS_USED_B, bdi_sched_wait, | 155 | wait_on_bit(&work->state, WS_INPROGRESS, bdi_sched_wait, |
| 191 | TASK_UNINTERRUPTIBLE); | 156 | TASK_UNINTERRUPTIBLE); |
| 192 | } | 157 | } |
| 193 | 158 | ||
| @@ -213,37 +178,28 @@ static void bdi_alloc_queue_work(struct backing_dev_info *bdi, | |||
| 213 | } | 178 | } |
| 214 | 179 | ||
| 215 | /** | 180 | /** |
| 216 | * bdi_sync_writeback - start and wait for writeback | 181 | * bdi_queue_work_onstack - start and wait for writeback |
| 217 | * @bdi: the backing device to write from | ||
| 218 | * @sb: write inodes from this super_block | 182 | * @sb: write inodes from this super_block |
| 219 | * | 183 | * |
| 220 | * Description: | 184 | * Description: |
| 221 | * This does WB_SYNC_ALL data integrity writeback and waits for the | 185 | * This function initiates writeback and waits for the operation to |
| 222 | * IO to complete. Callers must hold the sb s_umount semaphore for | 186 | * complete. Callers must hold the sb s_umount semaphore for |
| 223 | * reading, to avoid having the super disappear before we are done. | 187 | * reading, to avoid having the super disappear before we are done. |
| 224 | */ | 188 | */ |
| 225 | static void bdi_sync_writeback(struct backing_dev_info *bdi, | 189 | static void bdi_queue_work_onstack(struct wb_writeback_args *args) |
| 226 | struct super_block *sb) | ||
| 227 | { | 190 | { |
| 228 | struct wb_writeback_args args = { | ||
| 229 | .sb = sb, | ||
| 230 | .sync_mode = WB_SYNC_ALL, | ||
| 231 | .nr_pages = LONG_MAX, | ||
| 232 | .range_cyclic = 0, | ||
| 233 | }; | ||
| 234 | struct bdi_work work; | 191 | struct bdi_work work; |
| 235 | 192 | ||
| 236 | bdi_work_init(&work, &args); | 193 | bdi_work_init(&work, args); |
| 237 | work.state |= WS_ONSTACK; | 194 | __set_bit(WS_ONSTACK, &work.state); |
| 238 | 195 | ||
| 239 | bdi_queue_work(bdi, &work); | 196 | bdi_queue_work(args->sb->s_bdi, &work); |
| 240 | bdi_wait_on_work_clear(&work); | 197 | bdi_wait_on_work_done(&work); |
| 241 | } | 198 | } |
| 242 | 199 | ||
| 243 | /** | 200 | /** |
| 244 | * bdi_start_writeback - start writeback | 201 | * bdi_start_writeback - start writeback |
| 245 | * @bdi: the backing device to write from | 202 | * @bdi: the backing device to write from |
| 246 | * @sb: write inodes from this super_block | ||
| 247 | * @nr_pages: the number of pages to write | 203 | * @nr_pages: the number of pages to write |
| 248 | * | 204 | * |
| 249 | * Description: | 205 | * Description: |
| @@ -252,25 +208,34 @@ static void bdi_sync_writeback(struct backing_dev_info *bdi, | |||
| 252 | * completion. Caller need not hold sb s_umount semaphore. | 208 | * completion. Caller need not hold sb s_umount semaphore. |
| 253 | * | 209 | * |
| 254 | */ | 210 | */ |
| 255 | void bdi_start_writeback(struct backing_dev_info *bdi, struct super_block *sb, | 211 | void bdi_start_writeback(struct backing_dev_info *bdi, long nr_pages) |
| 256 | long nr_pages) | ||
| 257 | { | 212 | { |
| 258 | struct wb_writeback_args args = { | 213 | struct wb_writeback_args args = { |
| 259 | .sb = sb, | ||
| 260 | .sync_mode = WB_SYNC_NONE, | 214 | .sync_mode = WB_SYNC_NONE, |
| 261 | .nr_pages = nr_pages, | 215 | .nr_pages = nr_pages, |
| 262 | .range_cyclic = 1, | 216 | .range_cyclic = 1, |
| 263 | }; | 217 | }; |
| 264 | 218 | ||
| 265 | /* | 219 | bdi_alloc_queue_work(bdi, &args); |
| 266 | * We treat @nr_pages=0 as the special case to do background writeback, | 220 | } |
| 267 | * ie. to sync pages until the background dirty threshold is reached. | ||
| 268 | */ | ||
| 269 | if (!nr_pages) { | ||
| 270 | args.nr_pages = LONG_MAX; | ||
| 271 | args.for_background = 1; | ||
| 272 | } | ||
| 273 | 221 | ||
| 222 | /** | ||
| 223 | * bdi_start_background_writeback - start background writeback | ||
| 224 | * @bdi: the backing device to write from | ||
| 225 | * | ||
| 226 | * Description: | ||
| 227 | * This does WB_SYNC_NONE background writeback. The IO is only | ||
| 228 | * started when this function returns, we make no guarentees on | ||
| 229 | * completion. Caller need not hold sb s_umount semaphore. | ||
| 230 | */ | ||
| 231 | void bdi_start_background_writeback(struct backing_dev_info *bdi) | ||
| 232 | { | ||
| 233 | struct wb_writeback_args args = { | ||
| 234 | .sync_mode = WB_SYNC_NONE, | ||
| 235 | .nr_pages = LONG_MAX, | ||
| 236 | .for_background = 1, | ||
| 237 | .range_cyclic = 1, | ||
| 238 | }; | ||
| 274 | bdi_alloc_queue_work(bdi, &args); | 239 | bdi_alloc_queue_work(bdi, &args); |
| 275 | } | 240 | } |
| 276 | 241 | ||
| @@ -561,48 +526,30 @@ select_queue: | |||
| 561 | return ret; | 526 | return ret; |
| 562 | } | 527 | } |
| 563 | 528 | ||
| 564 | static void unpin_sb_for_writeback(struct super_block *sb) | ||
| 565 | { | ||
| 566 | up_read(&sb->s_umount); | ||
| 567 | put_super(sb); | ||
| 568 | } | ||
| 569 | |||
| 570 | enum sb_pin_state { | ||
| 571 | SB_PINNED, | ||
| 572 | SB_NOT_PINNED, | ||
| 573 | SB_PIN_FAILED | ||
| 574 | }; | ||
| 575 | |||
| 576 | /* | 529 | /* |
| 577 | * For WB_SYNC_NONE writeback, the caller does not have the sb pinned | 530 | * For background writeback the caller does not have the sb pinned |
| 578 | * before calling writeback. So make sure that we do pin it, so it doesn't | 531 | * before calling writeback. So make sure that we do pin it, so it doesn't |
| 579 | * go away while we are writing inodes from it. | 532 | * go away while we are writing inodes from it. |
| 580 | */ | 533 | */ |
| 581 | static enum sb_pin_state pin_sb_for_writeback(struct writeback_control *wbc, | 534 | static bool pin_sb_for_writeback(struct super_block *sb) |
| 582 | struct super_block *sb) | ||
| 583 | { | 535 | { |
| 584 | /* | ||
| 585 | * Caller must already hold the ref for this | ||
| 586 | */ | ||
| 587 | if (wbc->sync_mode == WB_SYNC_ALL) { | ||
| 588 | WARN_ON(!rwsem_is_locked(&sb->s_umount)); | ||
| 589 | return SB_NOT_PINNED; | ||
| 590 | } | ||
| 591 | spin_lock(&sb_lock); | 536 | spin_lock(&sb_lock); |
| 537 | if (list_empty(&sb->s_instances)) { | ||
| 538 | spin_unlock(&sb_lock); | ||
| 539 | return false; | ||
| 540 | } | ||
| 541 | |||
| 592 | sb->s_count++; | 542 | sb->s_count++; |
| 543 | spin_unlock(&sb_lock); | ||
| 544 | |||
| 593 | if (down_read_trylock(&sb->s_umount)) { | 545 | if (down_read_trylock(&sb->s_umount)) { |
| 594 | if (sb->s_root) { | 546 | if (sb->s_root) |
| 595 | spin_unlock(&sb_lock); | 547 | return true; |
| 596 | return SB_PINNED; | ||
| 597 | } | ||
| 598 | /* | ||
| 599 | * umounted, drop rwsem again and fall through to failure | ||
| 600 | */ | ||
| 601 | up_read(&sb->s_umount); | 548 | up_read(&sb->s_umount); |
| 602 | } | 549 | } |
| 603 | sb->s_count--; | 550 | |
| 604 | spin_unlock(&sb_lock); | 551 | put_super(sb); |
| 605 | return SB_PIN_FAILED; | 552 | return false; |
| 606 | } | 553 | } |
| 607 | 554 | ||
| 608 | /* | 555 | /* |
| @@ -681,24 +628,31 @@ static void writeback_inodes_wb(struct bdi_writeback *wb, | |||
| 681 | struct inode *inode = list_entry(wb->b_io.prev, | 628 | struct inode *inode = list_entry(wb->b_io.prev, |
| 682 | struct inode, i_list); | 629 | struct inode, i_list); |
| 683 | struct super_block *sb = inode->i_sb; | 630 | struct super_block *sb = inode->i_sb; |
| 684 | enum sb_pin_state state; | ||
| 685 | 631 | ||
| 686 | if (wbc->sb && sb != wbc->sb) { | 632 | if (wbc->sb) { |
| 687 | /* super block given and doesn't | 633 | /* |
| 688 | match, skip this inode */ | 634 | * We are requested to write out inodes for a specific |
| 689 | redirty_tail(inode); | 635 | * superblock. This means we already have s_umount |
| 690 | continue; | 636 | * taken by the caller which also waits for us to |
| 691 | } | 637 | * complete the writeout. |
| 692 | state = pin_sb_for_writeback(wbc, sb); | 638 | */ |
| 639 | if (sb != wbc->sb) { | ||
| 640 | redirty_tail(inode); | ||
| 641 | continue; | ||
| 642 | } | ||
| 693 | 643 | ||
| 694 | if (state == SB_PIN_FAILED) { | 644 | WARN_ON(!rwsem_is_locked(&sb->s_umount)); |
| 695 | requeue_io(inode); | 645 | |
| 696 | continue; | 646 | ret = writeback_sb_inodes(sb, wb, wbc); |
| 647 | } else { | ||
| 648 | if (!pin_sb_for_writeback(sb)) { | ||
| 649 | requeue_io(inode); | ||
| 650 | continue; | ||
| 651 | } | ||
| 652 | ret = writeback_sb_inodes(sb, wb, wbc); | ||
| 653 | drop_super(sb); | ||
| 697 | } | 654 | } |
| 698 | ret = writeback_sb_inodes(sb, wb, wbc); | ||
| 699 | 655 | ||
| 700 | if (state == SB_PINNED) | ||
| 701 | unpin_sb_for_writeback(sb); | ||
| 702 | if (ret) | 656 | if (ret) |
| 703 | break; | 657 | break; |
| 704 | } | 658 | } |
| @@ -911,7 +865,7 @@ long wb_do_writeback(struct bdi_writeback *wb, int force_wait) | |||
| 911 | * If this isn't a data integrity operation, just notify | 865 | * If this isn't a data integrity operation, just notify |
| 912 | * that we have seen this work and we are now starting it. | 866 | * that we have seen this work and we are now starting it. |
| 913 | */ | 867 | */ |
| 914 | if (args.sync_mode == WB_SYNC_NONE) | 868 | if (!test_bit(WS_ONSTACK, &work->state)) |
| 915 | wb_clear_pending(wb, work); | 869 | wb_clear_pending(wb, work); |
| 916 | 870 | ||
| 917 | wrote += wb_writeback(wb, &args); | 871 | wrote += wb_writeback(wb, &args); |
| @@ -920,7 +874,7 @@ long wb_do_writeback(struct bdi_writeback *wb, int force_wait) | |||
| 920 | * This is a data integrity writeback, so only do the | 874 | * This is a data integrity writeback, so only do the |
| 921 | * notification when we have completed the work. | 875 | * notification when we have completed the work. |
| 922 | */ | 876 | */ |
| 923 | if (args.sync_mode == WB_SYNC_ALL) | 877 | if (test_bit(WS_ONSTACK, &work->state)) |
| 924 | wb_clear_pending(wb, work); | 878 | wb_clear_pending(wb, work); |
| 925 | } | 879 | } |
| 926 | 880 | ||
| @@ -978,42 +932,32 @@ int bdi_writeback_task(struct bdi_writeback *wb) | |||
| 978 | } | 932 | } |
| 979 | 933 | ||
| 980 | /* | 934 | /* |
| 981 | * Schedule writeback for all backing devices. This does WB_SYNC_NONE | 935 | * Start writeback of `nr_pages' pages. If `nr_pages' is zero, write back |
| 982 | * writeback, for integrity writeback see bdi_sync_writeback(). | 936 | * the whole world. |
| 983 | */ | 937 | */ |
| 984 | static void bdi_writeback_all(struct super_block *sb, long nr_pages) | 938 | void wakeup_flusher_threads(long nr_pages) |
| 985 | { | 939 | { |
| 940 | struct backing_dev_info *bdi; | ||
| 986 | struct wb_writeback_args args = { | 941 | struct wb_writeback_args args = { |
| 987 | .sb = sb, | ||
| 988 | .nr_pages = nr_pages, | ||
| 989 | .sync_mode = WB_SYNC_NONE, | 942 | .sync_mode = WB_SYNC_NONE, |
| 990 | }; | 943 | }; |
| 991 | struct backing_dev_info *bdi; | ||
| 992 | 944 | ||
| 993 | rcu_read_lock(); | 945 | if (nr_pages) { |
| 946 | args.nr_pages = nr_pages; | ||
| 947 | } else { | ||
| 948 | args.nr_pages = global_page_state(NR_FILE_DIRTY) + | ||
| 949 | global_page_state(NR_UNSTABLE_NFS); | ||
| 950 | } | ||
| 994 | 951 | ||
| 952 | rcu_read_lock(); | ||
| 995 | list_for_each_entry_rcu(bdi, &bdi_list, bdi_list) { | 953 | list_for_each_entry_rcu(bdi, &bdi_list, bdi_list) { |
| 996 | if (!bdi_has_dirty_io(bdi)) | 954 | if (!bdi_has_dirty_io(bdi)) |
| 997 | continue; | 955 | continue; |
| 998 | |||
| 999 | bdi_alloc_queue_work(bdi, &args); | 956 | bdi_alloc_queue_work(bdi, &args); |
| 1000 | } | 957 | } |
| 1001 | |||
| 1002 | rcu_read_unlock(); | 958 | rcu_read_unlock(); |
| 1003 | } | 959 | } |
| 1004 | 960 | ||
| 1005 | /* | ||
| 1006 | * Start writeback of `nr_pages' pages. If `nr_pages' is zero, write back | ||
| 1007 | * the whole world. | ||
| 1008 | */ | ||
| 1009 | void wakeup_flusher_threads(long nr_pages) | ||
| 1010 | { | ||
| 1011 | if (nr_pages == 0) | ||
| 1012 | nr_pages = global_page_state(NR_FILE_DIRTY) + | ||
| 1013 | global_page_state(NR_UNSTABLE_NFS); | ||
| 1014 | bdi_writeback_all(NULL, nr_pages); | ||
| 1015 | } | ||
| 1016 | |||
| 1017 | static noinline void block_dump___mark_inode_dirty(struct inode *inode) | 961 | static noinline void block_dump___mark_inode_dirty(struct inode *inode) |
| 1018 | { | 962 | { |
| 1019 | if (inode->i_ino || strcmp(inode->i_sb->s_id, "bdev")) { | 963 | if (inode->i_ino || strcmp(inode->i_sb->s_id, "bdev")) { |
| @@ -1218,12 +1162,17 @@ void writeback_inodes_sb(struct super_block *sb) | |||
| 1218 | { | 1162 | { |
| 1219 | unsigned long nr_dirty = global_page_state(NR_FILE_DIRTY); | 1163 | unsigned long nr_dirty = global_page_state(NR_FILE_DIRTY); |
| 1220 | unsigned long nr_unstable = global_page_state(NR_UNSTABLE_NFS); | 1164 | unsigned long nr_unstable = global_page_state(NR_UNSTABLE_NFS); |
| 1221 | long nr_to_write; | 1165 | struct wb_writeback_args args = { |
| 1166 | .sb = sb, | ||
| 1167 | .sync_mode = WB_SYNC_NONE, | ||
| 1168 | }; | ||
| 1169 | |||
| 1170 | WARN_ON(!rwsem_is_locked(&sb->s_umount)); | ||
| 1222 | 1171 | ||
| 1223 | nr_to_write = nr_dirty + nr_unstable + | 1172 | args.nr_pages = nr_dirty + nr_unstable + |
| 1224 | (inodes_stat.nr_inodes - inodes_stat.nr_unused); | 1173 | (inodes_stat.nr_inodes - inodes_stat.nr_unused); |
| 1225 | 1174 | ||
| 1226 | bdi_start_writeback(sb->s_bdi, sb, nr_to_write); | 1175 | bdi_queue_work_onstack(&args); |
| 1227 | } | 1176 | } |
| 1228 | EXPORT_SYMBOL(writeback_inodes_sb); | 1177 | EXPORT_SYMBOL(writeback_inodes_sb); |
| 1229 | 1178 | ||
| @@ -1237,7 +1186,9 @@ EXPORT_SYMBOL(writeback_inodes_sb); | |||
| 1237 | int writeback_inodes_sb_if_idle(struct super_block *sb) | 1186 | int writeback_inodes_sb_if_idle(struct super_block *sb) |
| 1238 | { | 1187 | { |
| 1239 | if (!writeback_in_progress(sb->s_bdi)) { | 1188 | if (!writeback_in_progress(sb->s_bdi)) { |
| 1189 | down_read(&sb->s_umount); | ||
| 1240 | writeback_inodes_sb(sb); | 1190 | writeback_inodes_sb(sb); |
| 1191 | up_read(&sb->s_umount); | ||
| 1241 | return 1; | 1192 | return 1; |
| 1242 | } else | 1193 | } else |
| 1243 | return 0; | 1194 | return 0; |
| @@ -1253,7 +1204,16 @@ EXPORT_SYMBOL(writeback_inodes_sb_if_idle); | |||
| 1253 | */ | 1204 | */ |
| 1254 | void sync_inodes_sb(struct super_block *sb) | 1205 | void sync_inodes_sb(struct super_block *sb) |
| 1255 | { | 1206 | { |
| 1256 | bdi_sync_writeback(sb->s_bdi, sb); | 1207 | struct wb_writeback_args args = { |
| 1208 | .sb = sb, | ||
| 1209 | .sync_mode = WB_SYNC_ALL, | ||
| 1210 | .nr_pages = LONG_MAX, | ||
| 1211 | .range_cyclic = 0, | ||
| 1212 | }; | ||
| 1213 | |||
| 1214 | WARN_ON(!rwsem_is_locked(&sb->s_umount)); | ||
| 1215 | |||
| 1216 | bdi_queue_work_onstack(&args); | ||
| 1257 | wait_sb_inodes(sb); | 1217 | wait_sb_inodes(sb); |
| 1258 | } | 1218 | } |
| 1259 | EXPORT_SYMBOL(sync_inodes_sb); | 1219 | EXPORT_SYMBOL(sync_inodes_sb); |
diff --git a/fs/nfs/client.c b/fs/nfs/client.c index 7ec9b34a59f8..d25b5257b7a1 100644 --- a/fs/nfs/client.c +++ b/fs/nfs/client.c | |||
| @@ -1286,6 +1286,55 @@ static void nfs4_session_set_rwsize(struct nfs_server *server) | |||
| 1286 | #endif /* CONFIG_NFS_V4_1 */ | 1286 | #endif /* CONFIG_NFS_V4_1 */ |
| 1287 | } | 1287 | } |
| 1288 | 1288 | ||
| 1289 | static int nfs4_server_common_setup(struct nfs_server *server, | ||
| 1290 | struct nfs_fh *mntfh) | ||
| 1291 | { | ||
| 1292 | struct nfs_fattr *fattr; | ||
| 1293 | int error; | ||
| 1294 | |||
| 1295 | BUG_ON(!server->nfs_client); | ||
| 1296 | BUG_ON(!server->nfs_client->rpc_ops); | ||
| 1297 | BUG_ON(!server->nfs_client->rpc_ops->file_inode_ops); | ||
| 1298 | |||
| 1299 | fattr = nfs_alloc_fattr(); | ||
| 1300 | if (fattr == NULL) | ||
| 1301 | return -ENOMEM; | ||
| 1302 | |||
| 1303 | /* We must ensure the session is initialised first */ | ||
| 1304 | error = nfs4_init_session(server); | ||
| 1305 | if (error < 0) | ||
| 1306 | goto out; | ||
| 1307 | |||
| 1308 | /* Probe the root fh to retrieve its FSID and filehandle */ | ||
| 1309 | error = nfs4_get_rootfh(server, mntfh); | ||
| 1310 | if (error < 0) | ||
| 1311 | goto out; | ||
| 1312 | |||
| 1313 | dprintk("Server FSID: %llx:%llx\n", | ||
| 1314 | (unsigned long long) server->fsid.major, | ||
| 1315 | (unsigned long long) server->fsid.minor); | ||
| 1316 | dprintk("Mount FH: %d\n", mntfh->size); | ||
| 1317 | |||
| 1318 | nfs4_session_set_rwsize(server); | ||
| 1319 | |||
| 1320 | error = nfs_probe_fsinfo(server, mntfh, fattr); | ||
| 1321 | if (error < 0) | ||
| 1322 | goto out; | ||
| 1323 | |||
| 1324 | if (server->namelen == 0 || server->namelen > NFS4_MAXNAMLEN) | ||
| 1325 | server->namelen = NFS4_MAXNAMLEN; | ||
| 1326 | |||
| 1327 | spin_lock(&nfs_client_lock); | ||
| 1328 | list_add_tail(&server->client_link, &server->nfs_client->cl_superblocks); | ||
| 1329 | list_add_tail(&server->master_link, &nfs_volume_list); | ||
| 1330 | spin_unlock(&nfs_client_lock); | ||
| 1331 | |||
| 1332 | server->mount_time = jiffies; | ||
| 1333 | out: | ||
| 1334 | nfs_free_fattr(fattr); | ||
| 1335 | return error; | ||
| 1336 | } | ||
| 1337 | |||
| 1289 | /* | 1338 | /* |
| 1290 | * Create a version 4 volume record | 1339 | * Create a version 4 volume record |
| 1291 | */ | 1340 | */ |
| @@ -1346,7 +1395,6 @@ error: | |||
| 1346 | struct nfs_server *nfs4_create_server(const struct nfs_parsed_mount_data *data, | 1395 | struct nfs_server *nfs4_create_server(const struct nfs_parsed_mount_data *data, |
| 1347 | struct nfs_fh *mntfh) | 1396 | struct nfs_fh *mntfh) |
| 1348 | { | 1397 | { |
| 1349 | struct nfs_fattr *fattr; | ||
| 1350 | struct nfs_server *server; | 1398 | struct nfs_server *server; |
| 1351 | int error; | 1399 | int error; |
| 1352 | 1400 | ||
| @@ -1356,55 +1404,19 @@ struct nfs_server *nfs4_create_server(const struct nfs_parsed_mount_data *data, | |||
| 1356 | if (!server) | 1404 | if (!server) |
| 1357 | return ERR_PTR(-ENOMEM); | 1405 | return ERR_PTR(-ENOMEM); |
| 1358 | 1406 | ||
| 1359 | error = -ENOMEM; | ||
| 1360 | fattr = nfs_alloc_fattr(); | ||
| 1361 | if (fattr == NULL) | ||
| 1362 | goto error; | ||
| 1363 | |||
| 1364 | /* set up the general RPC client */ | 1407 | /* set up the general RPC client */ |
| 1365 | error = nfs4_init_server(server, data); | 1408 | error = nfs4_init_server(server, data); |
| 1366 | if (error < 0) | 1409 | if (error < 0) |
| 1367 | goto error; | 1410 | goto error; |
| 1368 | 1411 | ||
| 1369 | BUG_ON(!server->nfs_client); | 1412 | error = nfs4_server_common_setup(server, mntfh); |
| 1370 | BUG_ON(!server->nfs_client->rpc_ops); | ||
| 1371 | BUG_ON(!server->nfs_client->rpc_ops->file_inode_ops); | ||
| 1372 | |||
| 1373 | error = nfs4_init_session(server); | ||
| 1374 | if (error < 0) | ||
| 1375 | goto error; | ||
| 1376 | |||
| 1377 | /* Probe the root fh to retrieve its FSID */ | ||
| 1378 | error = nfs4_get_rootfh(server, mntfh); | ||
| 1379 | if (error < 0) | 1413 | if (error < 0) |
| 1380 | goto error; | 1414 | goto error; |
| 1381 | 1415 | ||
| 1382 | dprintk("Server FSID: %llx:%llx\n", | ||
| 1383 | (unsigned long long) server->fsid.major, | ||
| 1384 | (unsigned long long) server->fsid.minor); | ||
| 1385 | dprintk("Mount FH: %d\n", mntfh->size); | ||
| 1386 | |||
| 1387 | nfs4_session_set_rwsize(server); | ||
| 1388 | |||
| 1389 | error = nfs_probe_fsinfo(server, mntfh, fattr); | ||
| 1390 | if (error < 0) | ||
| 1391 | goto error; | ||
| 1392 | |||
| 1393 | if (server->namelen == 0 || server->namelen > NFS4_MAXNAMLEN) | ||
| 1394 | server->namelen = NFS4_MAXNAMLEN; | ||
| 1395 | |||
| 1396 | spin_lock(&nfs_client_lock); | ||
| 1397 | list_add_tail(&server->client_link, &server->nfs_client->cl_superblocks); | ||
| 1398 | list_add_tail(&server->master_link, &nfs_volume_list); | ||
| 1399 | spin_unlock(&nfs_client_lock); | ||
| 1400 | |||
| 1401 | server->mount_time = jiffies; | ||
| 1402 | dprintk("<-- nfs4_create_server() = %p\n", server); | 1416 | dprintk("<-- nfs4_create_server() = %p\n", server); |
| 1403 | nfs_free_fattr(fattr); | ||
| 1404 | return server; | 1417 | return server; |
| 1405 | 1418 | ||
| 1406 | error: | 1419 | error: |
| 1407 | nfs_free_fattr(fattr); | ||
| 1408 | nfs_free_server(server); | 1420 | nfs_free_server(server); |
| 1409 | dprintk("<-- nfs4_create_server() = error %d\n", error); | 1421 | dprintk("<-- nfs4_create_server() = error %d\n", error); |
| 1410 | return ERR_PTR(error); | 1422 | return ERR_PTR(error); |
| @@ -1418,7 +1430,6 @@ struct nfs_server *nfs4_create_referral_server(struct nfs_clone_mount *data, | |||
| 1418 | { | 1430 | { |
| 1419 | struct nfs_client *parent_client; | 1431 | struct nfs_client *parent_client; |
| 1420 | struct nfs_server *server, *parent_server; | 1432 | struct nfs_server *server, *parent_server; |
| 1421 | struct nfs_fattr *fattr; | ||
| 1422 | int error; | 1433 | int error; |
| 1423 | 1434 | ||
| 1424 | dprintk("--> nfs4_create_referral_server()\n"); | 1435 | dprintk("--> nfs4_create_referral_server()\n"); |
| @@ -1427,11 +1438,6 @@ struct nfs_server *nfs4_create_referral_server(struct nfs_clone_mount *data, | |||
| 1427 | if (!server) | 1438 | if (!server) |
| 1428 | return ERR_PTR(-ENOMEM); | 1439 | return ERR_PTR(-ENOMEM); |
| 1429 | 1440 | ||
| 1430 | error = -ENOMEM; | ||
| 1431 | fattr = nfs_alloc_fattr(); | ||
| 1432 | if (fattr == NULL) | ||
| 1433 | goto error; | ||
| 1434 | |||
| 1435 | parent_server = NFS_SB(data->sb); | 1441 | parent_server = NFS_SB(data->sb); |
| 1436 | parent_client = parent_server->nfs_client; | 1442 | parent_client = parent_server->nfs_client; |
| 1437 | 1443 | ||
| @@ -1456,40 +1462,14 @@ struct nfs_server *nfs4_create_referral_server(struct nfs_clone_mount *data, | |||
| 1456 | if (error < 0) | 1462 | if (error < 0) |
| 1457 | goto error; | 1463 | goto error; |
| 1458 | 1464 | ||
| 1459 | BUG_ON(!server->nfs_client); | 1465 | error = nfs4_server_common_setup(server, mntfh); |
| 1460 | BUG_ON(!server->nfs_client->rpc_ops); | ||
| 1461 | BUG_ON(!server->nfs_client->rpc_ops->file_inode_ops); | ||
| 1462 | |||
| 1463 | /* Probe the root fh to retrieve its FSID and filehandle */ | ||
| 1464 | error = nfs4_get_rootfh(server, mntfh); | ||
| 1465 | if (error < 0) | ||
| 1466 | goto error; | ||
| 1467 | |||
| 1468 | /* probe the filesystem info for this server filesystem */ | ||
| 1469 | error = nfs_probe_fsinfo(server, mntfh, fattr); | ||
| 1470 | if (error < 0) | 1466 | if (error < 0) |
| 1471 | goto error; | 1467 | goto error; |
| 1472 | 1468 | ||
| 1473 | if (server->namelen == 0 || server->namelen > NFS4_MAXNAMLEN) | ||
| 1474 | server->namelen = NFS4_MAXNAMLEN; | ||
| 1475 | |||
| 1476 | dprintk("Referral FSID: %llx:%llx\n", | ||
| 1477 | (unsigned long long) server->fsid.major, | ||
| 1478 | (unsigned long long) server->fsid.minor); | ||
| 1479 | |||
| 1480 | spin_lock(&nfs_client_lock); | ||
| 1481 | list_add_tail(&server->client_link, &server->nfs_client->cl_superblocks); | ||
| 1482 | list_add_tail(&server->master_link, &nfs_volume_list); | ||
| 1483 | spin_unlock(&nfs_client_lock); | ||
| 1484 | |||
| 1485 | server->mount_time = jiffies; | ||
| 1486 | |||
| 1487 | nfs_free_fattr(fattr); | ||
| 1488 | dprintk("<-- nfs_create_referral_server() = %p\n", server); | 1469 | dprintk("<-- nfs_create_referral_server() = %p\n", server); |
| 1489 | return server; | 1470 | return server; |
| 1490 | 1471 | ||
| 1491 | error: | 1472 | error: |
| 1492 | nfs_free_fattr(fattr); | ||
| 1493 | nfs_free_server(server); | 1473 | nfs_free_server(server); |
| 1494 | dprintk("<-- nfs4_create_referral_server() = error %d\n", error); | 1474 | dprintk("<-- nfs4_create_referral_server() = error %d\n", error); |
| 1495 | return ERR_PTR(error); | 1475 | return ERR_PTR(error); |
diff --git a/fs/nfs/getroot.c b/fs/nfs/getroot.c index 7428f7d6273b..a70e446e1605 100644 --- a/fs/nfs/getroot.c +++ b/fs/nfs/getroot.c | |||
| @@ -146,7 +146,7 @@ int nfs4_get_rootfh(struct nfs_server *server, struct nfs_fh *mntfh) | |||
| 146 | goto out; | 146 | goto out; |
| 147 | } | 147 | } |
| 148 | 148 | ||
| 149 | if (!(fsinfo.fattr->valid & NFS_ATTR_FATTR_MODE) | 149 | if (!(fsinfo.fattr->valid & NFS_ATTR_FATTR_TYPE) |
| 150 | || !S_ISDIR(fsinfo.fattr->mode)) { | 150 | || !S_ISDIR(fsinfo.fattr->mode)) { |
| 151 | printk(KERN_ERR "nfs4_get_rootfh:" | 151 | printk(KERN_ERR "nfs4_get_rootfh:" |
| 152 | " getroot encountered non-directory\n"); | 152 | " getroot encountered non-directory\n"); |
diff --git a/fs/nfs/nfs4xdr.c b/fs/nfs/nfs4xdr.c index 6bdef28efa33..65c8dae4b267 100644 --- a/fs/nfs/nfs4xdr.c +++ b/fs/nfs/nfs4xdr.c | |||
| @@ -862,8 +862,8 @@ static void encode_attrs(struct xdr_stream *xdr, const struct iattr *iap, const | |||
| 862 | bmval1 |= FATTR4_WORD1_TIME_ACCESS_SET; | 862 | bmval1 |= FATTR4_WORD1_TIME_ACCESS_SET; |
| 863 | *p++ = cpu_to_be32(NFS4_SET_TO_CLIENT_TIME); | 863 | *p++ = cpu_to_be32(NFS4_SET_TO_CLIENT_TIME); |
| 864 | *p++ = cpu_to_be32(0); | 864 | *p++ = cpu_to_be32(0); |
| 865 | *p++ = cpu_to_be32(iap->ia_mtime.tv_sec); | 865 | *p++ = cpu_to_be32(iap->ia_atime.tv_sec); |
| 866 | *p++ = cpu_to_be32(iap->ia_mtime.tv_nsec); | 866 | *p++ = cpu_to_be32(iap->ia_atime.tv_nsec); |
| 867 | } | 867 | } |
| 868 | else if (iap->ia_valid & ATTR_ATIME) { | 868 | else if (iap->ia_valid & ATTR_ATIME) { |
| 869 | bmval1 |= FATTR4_WORD1_TIME_ACCESS_SET; | 869 | bmval1 |= FATTR4_WORD1_TIME_ACCESS_SET; |
diff --git a/fs/nfs/super.c b/fs/nfs/super.c index 04214fc5c304..f9df16de4a56 100644 --- a/fs/nfs/super.c +++ b/fs/nfs/super.c | |||
| @@ -570,6 +570,22 @@ static void nfs_show_mountd_options(struct seq_file *m, struct nfs_server *nfss, | |||
| 570 | nfs_show_mountd_netid(m, nfss, showdefaults); | 570 | nfs_show_mountd_netid(m, nfss, showdefaults); |
| 571 | } | 571 | } |
| 572 | 572 | ||
| 573 | #ifdef CONFIG_NFS_V4 | ||
| 574 | static void nfs_show_nfsv4_options(struct seq_file *m, struct nfs_server *nfss, | ||
| 575 | int showdefaults) | ||
| 576 | { | ||
| 577 | struct nfs_client *clp = nfss->nfs_client; | ||
| 578 | |||
| 579 | seq_printf(m, ",clientaddr=%s", clp->cl_ipaddr); | ||
| 580 | seq_printf(m, ",minorversion=%u", clp->cl_minorversion); | ||
| 581 | } | ||
| 582 | #else | ||
| 583 | static void nfs_show_nfsv4_options(struct seq_file *m, struct nfs_server *nfss, | ||
| 584 | int showdefaults) | ||
| 585 | { | ||
| 586 | } | ||
| 587 | #endif | ||
| 588 | |||
| 573 | /* | 589 | /* |
| 574 | * Describe the mount options in force on this server representation | 590 | * Describe the mount options in force on this server representation |
| 575 | */ | 591 | */ |
| @@ -631,11 +647,9 @@ static void nfs_show_mount_options(struct seq_file *m, struct nfs_server *nfss, | |||
| 631 | 647 | ||
| 632 | if (version != 4) | 648 | if (version != 4) |
| 633 | nfs_show_mountd_options(m, nfss, showdefaults); | 649 | nfs_show_mountd_options(m, nfss, showdefaults); |
| 650 | else | ||
| 651 | nfs_show_nfsv4_options(m, nfss, showdefaults); | ||
| 634 | 652 | ||
| 635 | #ifdef CONFIG_NFS_V4 | ||
| 636 | if (clp->rpc_ops->version == 4) | ||
| 637 | seq_printf(m, ",clientaddr=%s", clp->cl_ipaddr); | ||
| 638 | #endif | ||
| 639 | if (nfss->options & NFS_OPTION_FSCACHE) | 653 | if (nfss->options & NFS_OPTION_FSCACHE) |
| 640 | seq_printf(m, ",fsc"); | 654 | seq_printf(m, ",fsc"); |
| 641 | } | 655 | } |
diff --git a/fs/ocfs2/reservations.c b/fs/ocfs2/reservations.c index 40650021fc24..d8b6e4259b80 100644 --- a/fs/ocfs2/reservations.c +++ b/fs/ocfs2/reservations.c | |||
| @@ -26,7 +26,6 @@ | |||
| 26 | 26 | ||
| 27 | #include <linux/fs.h> | 27 | #include <linux/fs.h> |
| 28 | #include <linux/types.h> | 28 | #include <linux/types.h> |
| 29 | #include <linux/slab.h> | ||
| 30 | #include <linux/highmem.h> | 29 | #include <linux/highmem.h> |
| 31 | #include <linux/bitops.h> | 30 | #include <linux/bitops.h> |
| 32 | #include <linux/list.h> | 31 | #include <linux/list.h> |
diff --git a/fs/proc/proc_devtree.c b/fs/proc/proc_devtree.c index ce94801f48ca..d9396a4fc7ff 100644 --- a/fs/proc/proc_devtree.c +++ b/fs/proc/proc_devtree.c | |||
| @@ -209,6 +209,9 @@ void proc_device_tree_add_node(struct device_node *np, | |||
| 209 | for (pp = np->properties; pp != NULL; pp = pp->next) { | 209 | for (pp = np->properties; pp != NULL; pp = pp->next) { |
| 210 | p = pp->name; | 210 | p = pp->name; |
| 211 | 211 | ||
| 212 | if (strchr(p, '/')) | ||
| 213 | continue; | ||
| 214 | |||
| 212 | if (duplicate_name(de, p)) | 215 | if (duplicate_name(de, p)) |
| 213 | p = fixup_name(np, de, p); | 216 | p = fixup_name(np, de, p); |
| 214 | 217 | ||
diff --git a/fs/proc/task_nommu.c b/fs/proc/task_nommu.c index 46d4b5d72bd3..cb6306e63843 100644 --- a/fs/proc/task_nommu.c +++ b/fs/proc/task_nommu.c | |||
| @@ -122,11 +122,20 @@ int task_statm(struct mm_struct *mm, int *shared, int *text, | |||
| 122 | return size; | 122 | return size; |
| 123 | } | 123 | } |
| 124 | 124 | ||
| 125 | static void pad_len_spaces(struct seq_file *m, int len) | ||
| 126 | { | ||
| 127 | len = 25 + sizeof(void*) * 6 - len; | ||
| 128 | if (len < 1) | ||
| 129 | len = 1; | ||
| 130 | seq_printf(m, "%*c", len, ' '); | ||
| 131 | } | ||
| 132 | |||
| 125 | /* | 133 | /* |
| 126 | * display a single VMA to a sequenced file | 134 | * display a single VMA to a sequenced file |
| 127 | */ | 135 | */ |
| 128 | static int nommu_vma_show(struct seq_file *m, struct vm_area_struct *vma) | 136 | static int nommu_vma_show(struct seq_file *m, struct vm_area_struct *vma) |
| 129 | { | 137 | { |
| 138 | struct mm_struct *mm = vma->vm_mm; | ||
| 130 | unsigned long ino = 0; | 139 | unsigned long ino = 0; |
| 131 | struct file *file; | 140 | struct file *file; |
| 132 | dev_t dev = 0; | 141 | dev_t dev = 0; |
| @@ -155,11 +164,14 @@ static int nommu_vma_show(struct seq_file *m, struct vm_area_struct *vma) | |||
| 155 | MAJOR(dev), MINOR(dev), ino, &len); | 164 | MAJOR(dev), MINOR(dev), ino, &len); |
| 156 | 165 | ||
| 157 | if (file) { | 166 | if (file) { |
| 158 | len = 25 + sizeof(void *) * 6 - len; | 167 | pad_len_spaces(m, len); |
| 159 | if (len < 1) | ||
| 160 | len = 1; | ||
| 161 | seq_printf(m, "%*c", len, ' '); | ||
| 162 | seq_path(m, &file->f_path, ""); | 168 | seq_path(m, &file->f_path, ""); |
| 169 | } else if (mm) { | ||
| 170 | if (vma->vm_start <= mm->start_stack && | ||
| 171 | vma->vm_end >= mm->start_stack) { | ||
| 172 | pad_len_spaces(m, len); | ||
| 173 | seq_puts(m, "[stack]"); | ||
| 174 | } | ||
| 163 | } | 175 | } |
| 164 | 176 | ||
| 165 | seq_putc(m, '\n'); | 177 | seq_putc(m, '\n'); |
diff --git a/fs/super.c b/fs/super.c index 5c35bc7a499e..938119ab8dcb 100644 --- a/fs/super.c +++ b/fs/super.c | |||
| @@ -374,6 +374,8 @@ void sync_supers(void) | |||
| 374 | up_read(&sb->s_umount); | 374 | up_read(&sb->s_umount); |
| 375 | 375 | ||
| 376 | spin_lock(&sb_lock); | 376 | spin_lock(&sb_lock); |
| 377 | /* lock was dropped, must reset next */ | ||
| 378 | list_safe_reset_next(sb, n, s_list); | ||
| 377 | __put_super(sb); | 379 | __put_super(sb); |
| 378 | } | 380 | } |
| 379 | } | 381 | } |
| @@ -405,6 +407,8 @@ void iterate_supers(void (*f)(struct super_block *, void *), void *arg) | |||
| 405 | up_read(&sb->s_umount); | 407 | up_read(&sb->s_umount); |
| 406 | 408 | ||
| 407 | spin_lock(&sb_lock); | 409 | spin_lock(&sb_lock); |
| 410 | /* lock was dropped, must reset next */ | ||
| 411 | list_safe_reset_next(sb, n, s_list); | ||
| 408 | __put_super(sb); | 412 | __put_super(sb); |
| 409 | } | 413 | } |
| 410 | spin_unlock(&sb_lock); | 414 | spin_unlock(&sb_lock); |
| @@ -585,6 +589,8 @@ static void do_emergency_remount(struct work_struct *work) | |||
| 585 | } | 589 | } |
| 586 | up_write(&sb->s_umount); | 590 | up_write(&sb->s_umount); |
| 587 | spin_lock(&sb_lock); | 591 | spin_lock(&sb_lock); |
| 592 | /* lock was dropped, must reset next */ | ||
| 593 | list_safe_reset_next(sb, n, s_list); | ||
| 588 | __put_super(sb); | 594 | __put_super(sb); |
| 589 | } | 595 | } |
| 590 | spin_unlock(&sb_lock); | 596 | spin_unlock(&sb_lock); |
diff --git a/fs/sysv/ialloc.c b/fs/sysv/ialloc.c index bbd69bdb0fa8..fcc498ec9b33 100644 --- a/fs/sysv/ialloc.c +++ b/fs/sysv/ialloc.c | |||
| @@ -25,6 +25,7 @@ | |||
| 25 | #include <linux/stat.h> | 25 | #include <linux/stat.h> |
| 26 | #include <linux/string.h> | 26 | #include <linux/string.h> |
| 27 | #include <linux/buffer_head.h> | 27 | #include <linux/buffer_head.h> |
| 28 | #include <linux/writeback.h> | ||
| 28 | #include "sysv.h" | 29 | #include "sysv.h" |
| 29 | 30 | ||
| 30 | /* We don't trust the value of | 31 | /* We don't trust the value of |
| @@ -139,6 +140,9 @@ struct inode * sysv_new_inode(const struct inode * dir, mode_t mode) | |||
| 139 | struct inode *inode; | 140 | struct inode *inode; |
| 140 | sysv_ino_t ino; | 141 | sysv_ino_t ino; |
| 141 | unsigned count; | 142 | unsigned count; |
| 143 | struct writeback_control wbc = { | ||
| 144 | .sync_mode = WB_SYNC_NONE | ||
| 145 | }; | ||
| 142 | 146 | ||
| 143 | inode = new_inode(sb); | 147 | inode = new_inode(sb); |
| 144 | if (!inode) | 148 | if (!inode) |
| @@ -168,7 +172,7 @@ struct inode * sysv_new_inode(const struct inode * dir, mode_t mode) | |||
| 168 | insert_inode_hash(inode); | 172 | insert_inode_hash(inode); |
| 169 | mark_inode_dirty(inode); | 173 | mark_inode_dirty(inode); |
| 170 | 174 | ||
| 171 | sysv_write_inode(inode, 0); /* ensure inode not allocated again */ | 175 | sysv_write_inode(inode, &wbc); /* ensure inode not allocated again */ |
| 172 | mark_inode_dirty(inode); /* cleared by sysv_write_inode() */ | 176 | mark_inode_dirty(inode); /* cleared by sysv_write_inode() */ |
| 173 | /* That's it. */ | 177 | /* That's it. */ |
| 174 | unlock_super(sb); | 178 | unlock_super(sb); |
diff --git a/fs/ubifs/budget.c b/fs/ubifs/budget.c index 076ca50e9933..c8ff0d1ae5d3 100644 --- a/fs/ubifs/budget.c +++ b/fs/ubifs/budget.c | |||
| @@ -62,7 +62,9 @@ | |||
| 62 | */ | 62 | */ |
| 63 | static void shrink_liability(struct ubifs_info *c, int nr_to_write) | 63 | static void shrink_liability(struct ubifs_info *c, int nr_to_write) |
| 64 | { | 64 | { |
| 65 | down_read(&c->vfs_sb->s_umount); | ||
| 65 | writeback_inodes_sb(c->vfs_sb); | 66 | writeback_inodes_sb(c->vfs_sb); |
| 67 | up_read(&c->vfs_sb->s_umount); | ||
| 66 | } | 68 | } |
| 67 | 69 | ||
| 68 | /** | 70 | /** |
diff --git a/fs/xfs/linux-2.6/xfs_export.c b/fs/xfs/linux-2.6/xfs_export.c index 846b75aeb2ab..e7839ee49e43 100644 --- a/fs/xfs/linux-2.6/xfs_export.c +++ b/fs/xfs/linux-2.6/xfs_export.c | |||
| @@ -128,13 +128,12 @@ xfs_nfs_get_inode( | |||
| 128 | return ERR_PTR(-ESTALE); | 128 | return ERR_PTR(-ESTALE); |
| 129 | 129 | ||
| 130 | /* | 130 | /* |
| 131 | * The XFS_IGET_BULKSTAT means that an invalid inode number is just | 131 | * The XFS_IGET_UNTRUSTED means that an invalid inode number is just |
| 132 | * fine and not an indication of a corrupted filesystem. Because | 132 | * fine and not an indication of a corrupted filesystem as clients can |
| 133 | * clients can send any kind of invalid file handle, e.g. after | 133 | * send invalid file handles and we have to handle it gracefully.. |
| 134 | * a restore on the server we have to deal with this case gracefully. | ||
| 135 | */ | 134 | */ |
| 136 | error = xfs_iget(mp, NULL, ino, XFS_IGET_BULKSTAT, | 135 | error = xfs_iget(mp, NULL, ino, XFS_IGET_UNTRUSTED, |
| 137 | XFS_ILOCK_SHARED, &ip, 0); | 136 | XFS_ILOCK_SHARED, &ip); |
| 138 | if (error) { | 137 | if (error) { |
| 139 | /* | 138 | /* |
| 140 | * EINVAL means the inode cluster doesn't exist anymore. | 139 | * EINVAL means the inode cluster doesn't exist anymore. |
diff --git a/fs/xfs/linux-2.6/xfs_ioctl.c b/fs/xfs/linux-2.6/xfs_ioctl.c index 699b60cbab9c..e59a81062830 100644 --- a/fs/xfs/linux-2.6/xfs_ioctl.c +++ b/fs/xfs/linux-2.6/xfs_ioctl.c | |||
| @@ -679,10 +679,9 @@ xfs_ioc_bulkstat( | |||
| 679 | error = xfs_bulkstat_single(mp, &inlast, | 679 | error = xfs_bulkstat_single(mp, &inlast, |
| 680 | bulkreq.ubuffer, &done); | 680 | bulkreq.ubuffer, &done); |
| 681 | else /* XFS_IOC_FSBULKSTAT */ | 681 | else /* XFS_IOC_FSBULKSTAT */ |
| 682 | error = xfs_bulkstat(mp, &inlast, &count, | 682 | error = xfs_bulkstat(mp, &inlast, &count, xfs_bulkstat_one, |
| 683 | (bulkstat_one_pf)xfs_bulkstat_one, NULL, | 683 | sizeof(xfs_bstat_t), bulkreq.ubuffer, |
| 684 | sizeof(xfs_bstat_t), bulkreq.ubuffer, | 684 | &done); |
| 685 | BULKSTAT_FG_QUICK, &done); | ||
| 686 | 685 | ||
| 687 | if (error) | 686 | if (error) |
| 688 | return -error; | 687 | return -error; |
diff --git a/fs/xfs/linux-2.6/xfs_ioctl32.c b/fs/xfs/linux-2.6/xfs_ioctl32.c index 9287135e9bfc..52ed49e6465c 100644 --- a/fs/xfs/linux-2.6/xfs_ioctl32.c +++ b/fs/xfs/linux-2.6/xfs_ioctl32.c | |||
| @@ -237,15 +237,12 @@ xfs_bulkstat_one_compat( | |||
| 237 | xfs_ino_t ino, /* inode number to get data for */ | 237 | xfs_ino_t ino, /* inode number to get data for */ |
| 238 | void __user *buffer, /* buffer to place output in */ | 238 | void __user *buffer, /* buffer to place output in */ |
| 239 | int ubsize, /* size of buffer */ | 239 | int ubsize, /* size of buffer */ |
| 240 | void *private_data, /* my private data */ | ||
| 241 | xfs_daddr_t bno, /* starting bno of inode cluster */ | ||
| 242 | int *ubused, /* bytes used by me */ | 240 | int *ubused, /* bytes used by me */ |
| 243 | void *dibuff, /* on-disk inode buffer */ | ||
| 244 | int *stat) /* BULKSTAT_RV_... */ | 241 | int *stat) /* BULKSTAT_RV_... */ |
| 245 | { | 242 | { |
| 246 | return xfs_bulkstat_one_int(mp, ino, buffer, ubsize, | 243 | return xfs_bulkstat_one_int(mp, ino, buffer, ubsize, |
| 247 | xfs_bulkstat_one_fmt_compat, bno, | 244 | xfs_bulkstat_one_fmt_compat, |
| 248 | ubused, dibuff, stat); | 245 | ubused, stat); |
| 249 | } | 246 | } |
| 250 | 247 | ||
| 251 | /* copied from xfs_ioctl.c */ | 248 | /* copied from xfs_ioctl.c */ |
| @@ -298,13 +295,11 @@ xfs_compat_ioc_bulkstat( | |||
| 298 | int res; | 295 | int res; |
| 299 | 296 | ||
| 300 | error = xfs_bulkstat_one_compat(mp, inlast, bulkreq.ubuffer, | 297 | error = xfs_bulkstat_one_compat(mp, inlast, bulkreq.ubuffer, |
| 301 | sizeof(compat_xfs_bstat_t), | 298 | sizeof(compat_xfs_bstat_t), 0, &res); |
| 302 | NULL, 0, NULL, NULL, &res); | ||
| 303 | } else if (cmd == XFS_IOC_FSBULKSTAT_32) { | 299 | } else if (cmd == XFS_IOC_FSBULKSTAT_32) { |
| 304 | error = xfs_bulkstat(mp, &inlast, &count, | 300 | error = xfs_bulkstat(mp, &inlast, &count, |
| 305 | xfs_bulkstat_one_compat, NULL, | 301 | xfs_bulkstat_one_compat, sizeof(compat_xfs_bstat_t), |
| 306 | sizeof(compat_xfs_bstat_t), bulkreq.ubuffer, | 302 | bulkreq.ubuffer, &done); |
| 307 | BULKSTAT_FG_QUICK, &done); | ||
| 308 | } else | 303 | } else |
| 309 | error = XFS_ERROR(EINVAL); | 304 | error = XFS_ERROR(EINVAL); |
| 310 | if (error) | 305 | if (error) |
diff --git a/fs/xfs/quota/xfs_qm.c b/fs/xfs/quota/xfs_qm.c index 2d8b7bc792c9..8c117ff2e3ab 100644 --- a/fs/xfs/quota/xfs_qm.c +++ b/fs/xfs/quota/xfs_qm.c | |||
| @@ -1632,10 +1632,7 @@ xfs_qm_dqusage_adjust( | |||
| 1632 | xfs_ino_t ino, /* inode number to get data for */ | 1632 | xfs_ino_t ino, /* inode number to get data for */ |
| 1633 | void __user *buffer, /* not used */ | 1633 | void __user *buffer, /* not used */ |
| 1634 | int ubsize, /* not used */ | 1634 | int ubsize, /* not used */ |
| 1635 | void *private_data, /* not used */ | ||
| 1636 | xfs_daddr_t bno, /* starting block of inode cluster */ | ||
| 1637 | int *ubused, /* not used */ | 1635 | int *ubused, /* not used */ |
| 1638 | void *dip, /* on-disk inode pointer (not used) */ | ||
| 1639 | int *res) /* result code value */ | 1636 | int *res) /* result code value */ |
| 1640 | { | 1637 | { |
| 1641 | xfs_inode_t *ip; | 1638 | xfs_inode_t *ip; |
| @@ -1660,7 +1657,7 @@ xfs_qm_dqusage_adjust( | |||
| 1660 | * the case in all other instances. It's OK that we do this because | 1657 | * the case in all other instances. It's OK that we do this because |
| 1661 | * quotacheck is done only at mount time. | 1658 | * quotacheck is done only at mount time. |
| 1662 | */ | 1659 | */ |
| 1663 | if ((error = xfs_iget(mp, NULL, ino, 0, XFS_ILOCK_EXCL, &ip, bno))) { | 1660 | if ((error = xfs_iget(mp, NULL, ino, 0, XFS_ILOCK_EXCL, &ip))) { |
| 1664 | *res = BULKSTAT_RV_NOTHING; | 1661 | *res = BULKSTAT_RV_NOTHING; |
| 1665 | return error; | 1662 | return error; |
| 1666 | } | 1663 | } |
| @@ -1796,12 +1793,13 @@ xfs_qm_quotacheck( | |||
| 1796 | * Iterate thru all the inodes in the file system, | 1793 | * Iterate thru all the inodes in the file system, |
| 1797 | * adjusting the corresponding dquot counters in core. | 1794 | * adjusting the corresponding dquot counters in core. |
| 1798 | */ | 1795 | */ |
| 1799 | if ((error = xfs_bulkstat(mp, &lastino, &count, | 1796 | error = xfs_bulkstat(mp, &lastino, &count, |
| 1800 | xfs_qm_dqusage_adjust, NULL, | 1797 | xfs_qm_dqusage_adjust, |
| 1801 | structsz, NULL, BULKSTAT_FG_IGET, &done))) | 1798 | structsz, NULL, &done); |
| 1799 | if (error) | ||
| 1802 | break; | 1800 | break; |
| 1803 | 1801 | ||
| 1804 | } while (! done); | 1802 | } while (!done); |
| 1805 | 1803 | ||
| 1806 | /* | 1804 | /* |
| 1807 | * We've made all the changes that we need to make incore. | 1805 | * We've made all the changes that we need to make incore. |
| @@ -1889,14 +1887,14 @@ xfs_qm_init_quotainos( | |||
| 1889 | mp->m_sb.sb_uquotino != NULLFSINO) { | 1887 | mp->m_sb.sb_uquotino != NULLFSINO) { |
| 1890 | ASSERT(mp->m_sb.sb_uquotino > 0); | 1888 | ASSERT(mp->m_sb.sb_uquotino > 0); |
| 1891 | if ((error = xfs_iget(mp, NULL, mp->m_sb.sb_uquotino, | 1889 | if ((error = xfs_iget(mp, NULL, mp->m_sb.sb_uquotino, |
| 1892 | 0, 0, &uip, 0))) | 1890 | 0, 0, &uip))) |
| 1893 | return XFS_ERROR(error); | 1891 | return XFS_ERROR(error); |
| 1894 | } | 1892 | } |
| 1895 | if (XFS_IS_OQUOTA_ON(mp) && | 1893 | if (XFS_IS_OQUOTA_ON(mp) && |
| 1896 | mp->m_sb.sb_gquotino != NULLFSINO) { | 1894 | mp->m_sb.sb_gquotino != NULLFSINO) { |
| 1897 | ASSERT(mp->m_sb.sb_gquotino > 0); | 1895 | ASSERT(mp->m_sb.sb_gquotino > 0); |
| 1898 | if ((error = xfs_iget(mp, NULL, mp->m_sb.sb_gquotino, | 1896 | if ((error = xfs_iget(mp, NULL, mp->m_sb.sb_gquotino, |
| 1899 | 0, 0, &gip, 0))) { | 1897 | 0, 0, &gip))) { |
| 1900 | if (uip) | 1898 | if (uip) |
| 1901 | IRELE(uip); | 1899 | IRELE(uip); |
| 1902 | return XFS_ERROR(error); | 1900 | return XFS_ERROR(error); |
diff --git a/fs/xfs/quota/xfs_qm_syscalls.c b/fs/xfs/quota/xfs_qm_syscalls.c index 92b002f1805f..b4487764e923 100644 --- a/fs/xfs/quota/xfs_qm_syscalls.c +++ b/fs/xfs/quota/xfs_qm_syscalls.c | |||
| @@ -262,7 +262,7 @@ xfs_qm_scall_trunc_qfiles( | |||
| 262 | } | 262 | } |
| 263 | 263 | ||
| 264 | if ((flags & XFS_DQ_USER) && mp->m_sb.sb_uquotino != NULLFSINO) { | 264 | if ((flags & XFS_DQ_USER) && mp->m_sb.sb_uquotino != NULLFSINO) { |
| 265 | error = xfs_iget(mp, NULL, mp->m_sb.sb_uquotino, 0, 0, &qip, 0); | 265 | error = xfs_iget(mp, NULL, mp->m_sb.sb_uquotino, 0, 0, &qip); |
| 266 | if (!error) { | 266 | if (!error) { |
| 267 | error = xfs_truncate_file(mp, qip); | 267 | error = xfs_truncate_file(mp, qip); |
| 268 | IRELE(qip); | 268 | IRELE(qip); |
| @@ -271,7 +271,7 @@ xfs_qm_scall_trunc_qfiles( | |||
| 271 | 271 | ||
| 272 | if ((flags & (XFS_DQ_GROUP|XFS_DQ_PROJ)) && | 272 | if ((flags & (XFS_DQ_GROUP|XFS_DQ_PROJ)) && |
| 273 | mp->m_sb.sb_gquotino != NULLFSINO) { | 273 | mp->m_sb.sb_gquotino != NULLFSINO) { |
| 274 | error2 = xfs_iget(mp, NULL, mp->m_sb.sb_gquotino, 0, 0, &qip, 0); | 274 | error2 = xfs_iget(mp, NULL, mp->m_sb.sb_gquotino, 0, 0, &qip); |
| 275 | if (!error2) { | 275 | if (!error2) { |
| 276 | error2 = xfs_truncate_file(mp, qip); | 276 | error2 = xfs_truncate_file(mp, qip); |
| 277 | IRELE(qip); | 277 | IRELE(qip); |
| @@ -417,12 +417,12 @@ xfs_qm_scall_getqstat( | |||
| 417 | } | 417 | } |
| 418 | if (!uip && mp->m_sb.sb_uquotino != NULLFSINO) { | 418 | if (!uip && mp->m_sb.sb_uquotino != NULLFSINO) { |
| 419 | if (xfs_iget(mp, NULL, mp->m_sb.sb_uquotino, | 419 | if (xfs_iget(mp, NULL, mp->m_sb.sb_uquotino, |
| 420 | 0, 0, &uip, 0) == 0) | 420 | 0, 0, &uip) == 0) |
| 421 | tempuqip = B_TRUE; | 421 | tempuqip = B_TRUE; |
| 422 | } | 422 | } |
| 423 | if (!gip && mp->m_sb.sb_gquotino != NULLFSINO) { | 423 | if (!gip && mp->m_sb.sb_gquotino != NULLFSINO) { |
| 424 | if (xfs_iget(mp, NULL, mp->m_sb.sb_gquotino, | 424 | if (xfs_iget(mp, NULL, mp->m_sb.sb_gquotino, |
| 425 | 0, 0, &gip, 0) == 0) | 425 | 0, 0, &gip) == 0) |
| 426 | tempgqip = B_TRUE; | 426 | tempgqip = B_TRUE; |
| 427 | } | 427 | } |
| 428 | if (uip) { | 428 | if (uip) { |
| @@ -1109,10 +1109,7 @@ xfs_qm_internalqcheck_adjust( | |||
| 1109 | xfs_ino_t ino, /* inode number to get data for */ | 1109 | xfs_ino_t ino, /* inode number to get data for */ |
| 1110 | void __user *buffer, /* not used */ | 1110 | void __user *buffer, /* not used */ |
| 1111 | int ubsize, /* not used */ | 1111 | int ubsize, /* not used */ |
| 1112 | void *private_data, /* not used */ | ||
| 1113 | xfs_daddr_t bno, /* starting block of inode cluster */ | ||
| 1114 | int *ubused, /* not used */ | 1112 | int *ubused, /* not used */ |
| 1115 | void *dip, /* not used */ | ||
| 1116 | int *res) /* bulkstat result code */ | 1113 | int *res) /* bulkstat result code */ |
| 1117 | { | 1114 | { |
| 1118 | xfs_inode_t *ip; | 1115 | xfs_inode_t *ip; |
| @@ -1134,7 +1131,7 @@ xfs_qm_internalqcheck_adjust( | |||
| 1134 | ipreleased = B_FALSE; | 1131 | ipreleased = B_FALSE; |
| 1135 | again: | 1132 | again: |
| 1136 | lock_flags = XFS_ILOCK_SHARED; | 1133 | lock_flags = XFS_ILOCK_SHARED; |
| 1137 | if ((error = xfs_iget(mp, NULL, ino, 0, lock_flags, &ip, bno))) { | 1134 | if ((error = xfs_iget(mp, NULL, ino, 0, lock_flags, &ip))) { |
| 1138 | *res = BULKSTAT_RV_NOTHING; | 1135 | *res = BULKSTAT_RV_NOTHING; |
| 1139 | return (error); | 1136 | return (error); |
| 1140 | } | 1137 | } |
| @@ -1205,15 +1202,15 @@ xfs_qm_internalqcheck( | |||
| 1205 | * Iterate thru all the inodes in the file system, | 1202 | * Iterate thru all the inodes in the file system, |
| 1206 | * adjusting the corresponding dquot counters | 1203 | * adjusting the corresponding dquot counters |
| 1207 | */ | 1204 | */ |
| 1208 | if ((error = xfs_bulkstat(mp, &lastino, &count, | 1205 | error = xfs_bulkstat(mp, &lastino, &count, |
| 1209 | xfs_qm_internalqcheck_adjust, NULL, | 1206 | xfs_qm_internalqcheck_adjust, |
| 1210 | 0, NULL, BULKSTAT_FG_IGET, &done))) { | 1207 | 0, NULL, &done); |
| 1208 | if (error) { | ||
| 1209 | cmn_err(CE_DEBUG, "Bulkstat returned error 0x%x", error); | ||
| 1211 | break; | 1210 | break; |
| 1212 | } | 1211 | } |
| 1213 | } while (! done); | 1212 | } while (!done); |
| 1214 | if (error) { | 1213 | |
| 1215 | cmn_err(CE_DEBUG, "Bulkstat returned error 0x%x", error); | ||
| 1216 | } | ||
| 1217 | cmn_err(CE_DEBUG, "Checking results against system dquots"); | 1214 | cmn_err(CE_DEBUG, "Checking results against system dquots"); |
| 1218 | for (i = 0; i < qmtest_hashmask; i++) { | 1215 | for (i = 0; i < qmtest_hashmask; i++) { |
| 1219 | xfs_dqtest_t *d, *n; | 1216 | xfs_dqtest_t *d, *n; |
diff --git a/fs/xfs/xfs_dfrag.c b/fs/xfs/xfs_dfrag.c index 5bba29a07812..7f159d2a429a 100644 --- a/fs/xfs/xfs_dfrag.c +++ b/fs/xfs/xfs_dfrag.c | |||
| @@ -69,7 +69,9 @@ xfs_swapext( | |||
| 69 | goto out; | 69 | goto out; |
| 70 | } | 70 | } |
| 71 | 71 | ||
| 72 | if (!(file->f_mode & FMODE_WRITE) || (file->f_flags & O_APPEND)) { | 72 | if (!(file->f_mode & FMODE_WRITE) || |
| 73 | !(file->f_mode & FMODE_READ) || | ||
| 74 | (file->f_flags & O_APPEND)) { | ||
| 73 | error = XFS_ERROR(EBADF); | 75 | error = XFS_ERROR(EBADF); |
| 74 | goto out_put_file; | 76 | goto out_put_file; |
| 75 | } | 77 | } |
| @@ -81,6 +83,7 @@ xfs_swapext( | |||
| 81 | } | 83 | } |
| 82 | 84 | ||
| 83 | if (!(tmp_file->f_mode & FMODE_WRITE) || | 85 | if (!(tmp_file->f_mode & FMODE_WRITE) || |
| 86 | !(tmp_file->f_mode & FMODE_READ) || | ||
| 84 | (tmp_file->f_flags & O_APPEND)) { | 87 | (tmp_file->f_flags & O_APPEND)) { |
| 85 | error = XFS_ERROR(EBADF); | 88 | error = XFS_ERROR(EBADF); |
| 86 | goto out_put_tmp_file; | 89 | goto out_put_tmp_file; |
diff --git a/fs/xfs/xfs_ialloc.c b/fs/xfs/xfs_ialloc.c index 9d884c127bb9..c7142a064c48 100644 --- a/fs/xfs/xfs_ialloc.c +++ b/fs/xfs/xfs_ialloc.c | |||
| @@ -1203,6 +1203,63 @@ error0: | |||
| 1203 | return error; | 1203 | return error; |
| 1204 | } | 1204 | } |
| 1205 | 1205 | ||
| 1206 | STATIC int | ||
| 1207 | xfs_imap_lookup( | ||
| 1208 | struct xfs_mount *mp, | ||
| 1209 | struct xfs_trans *tp, | ||
| 1210 | xfs_agnumber_t agno, | ||
| 1211 | xfs_agino_t agino, | ||
| 1212 | xfs_agblock_t agbno, | ||
| 1213 | xfs_agblock_t *chunk_agbno, | ||
| 1214 | xfs_agblock_t *offset_agbno, | ||
| 1215 | int flags) | ||
| 1216 | { | ||
| 1217 | struct xfs_inobt_rec_incore rec; | ||
| 1218 | struct xfs_btree_cur *cur; | ||
| 1219 | struct xfs_buf *agbp; | ||
| 1220 | xfs_agino_t startino; | ||
| 1221 | int error; | ||
| 1222 | int i; | ||
| 1223 | |||
| 1224 | error = xfs_ialloc_read_agi(mp, tp, agno, &agbp); | ||
| 1225 | if (error) { | ||
| 1226 | xfs_fs_cmn_err(CE_ALERT, mp, "xfs_imap: " | ||
| 1227 | "xfs_ialloc_read_agi() returned " | ||
| 1228 | "error %d, agno %d", | ||
| 1229 | error, agno); | ||
| 1230 | return error; | ||
| 1231 | } | ||
| 1232 | |||
| 1233 | /* | ||
| 1234 | * derive and lookup the exact inode record for the given agino. If the | ||
| 1235 | * record cannot be found, then it's an invalid inode number and we | ||
| 1236 | * should abort. | ||
| 1237 | */ | ||
| 1238 | cur = xfs_inobt_init_cursor(mp, tp, agbp, agno); | ||
| 1239 | startino = agino & ~(XFS_IALLOC_INODES(mp) - 1); | ||
| 1240 | error = xfs_inobt_lookup(cur, startino, XFS_LOOKUP_EQ, &i); | ||
| 1241 | if (!error) { | ||
| 1242 | if (i) | ||
| 1243 | error = xfs_inobt_get_rec(cur, &rec, &i); | ||
| 1244 | if (!error && i == 0) | ||
| 1245 | error = EINVAL; | ||
| 1246 | } | ||
| 1247 | |||
| 1248 | xfs_trans_brelse(tp, agbp); | ||
| 1249 | xfs_btree_del_cursor(cur, XFS_BTREE_NOERROR); | ||
| 1250 | if (error) | ||
| 1251 | return error; | ||
| 1252 | |||
| 1253 | /* for untrusted inodes check it is allocated first */ | ||
| 1254 | if ((flags & XFS_IGET_UNTRUSTED) && | ||
| 1255 | (rec.ir_free & XFS_INOBT_MASK(agino - rec.ir_startino))) | ||
| 1256 | return EINVAL; | ||
| 1257 | |||
| 1258 | *chunk_agbno = XFS_AGINO_TO_AGBNO(mp, rec.ir_startino); | ||
| 1259 | *offset_agbno = agbno - *chunk_agbno; | ||
| 1260 | return 0; | ||
| 1261 | } | ||
| 1262 | |||
| 1206 | /* | 1263 | /* |
| 1207 | * Return the location of the inode in imap, for mapping it into a buffer. | 1264 | * Return the location of the inode in imap, for mapping it into a buffer. |
| 1208 | */ | 1265 | */ |
| @@ -1235,8 +1292,11 @@ xfs_imap( | |||
| 1235 | if (agno >= mp->m_sb.sb_agcount || agbno >= mp->m_sb.sb_agblocks || | 1292 | if (agno >= mp->m_sb.sb_agcount || agbno >= mp->m_sb.sb_agblocks || |
| 1236 | ino != XFS_AGINO_TO_INO(mp, agno, agino)) { | 1293 | ino != XFS_AGINO_TO_INO(mp, agno, agino)) { |
| 1237 | #ifdef DEBUG | 1294 | #ifdef DEBUG |
| 1238 | /* no diagnostics for bulkstat, ino comes from userspace */ | 1295 | /* |
| 1239 | if (flags & XFS_IGET_BULKSTAT) | 1296 | * Don't output diagnostic information for untrusted inodes |
| 1297 | * as they can be invalid without implying corruption. | ||
| 1298 | */ | ||
| 1299 | if (flags & XFS_IGET_UNTRUSTED) | ||
| 1240 | return XFS_ERROR(EINVAL); | 1300 | return XFS_ERROR(EINVAL); |
| 1241 | if (agno >= mp->m_sb.sb_agcount) { | 1301 | if (agno >= mp->m_sb.sb_agcount) { |
| 1242 | xfs_fs_cmn_err(CE_ALERT, mp, | 1302 | xfs_fs_cmn_err(CE_ALERT, mp, |
| @@ -1263,6 +1323,23 @@ xfs_imap( | |||
| 1263 | return XFS_ERROR(EINVAL); | 1323 | return XFS_ERROR(EINVAL); |
| 1264 | } | 1324 | } |
| 1265 | 1325 | ||
| 1326 | blks_per_cluster = XFS_INODE_CLUSTER_SIZE(mp) >> mp->m_sb.sb_blocklog; | ||
| 1327 | |||
| 1328 | /* | ||
| 1329 | * For bulkstat and handle lookups, we have an untrusted inode number | ||
| 1330 | * that we have to verify is valid. We cannot do this just by reading | ||
| 1331 | * the inode buffer as it may have been unlinked and removed leaving | ||
| 1332 | * inodes in stale state on disk. Hence we have to do a btree lookup | ||
| 1333 | * in all cases where an untrusted inode number is passed. | ||
| 1334 | */ | ||
| 1335 | if (flags & XFS_IGET_UNTRUSTED) { | ||
| 1336 | error = xfs_imap_lookup(mp, tp, agno, agino, agbno, | ||
| 1337 | &chunk_agbno, &offset_agbno, flags); | ||
| 1338 | if (error) | ||
| 1339 | return error; | ||
| 1340 | goto out_map; | ||
| 1341 | } | ||
| 1342 | |||
| 1266 | /* | 1343 | /* |
| 1267 | * If the inode cluster size is the same as the blocksize or | 1344 | * If the inode cluster size is the same as the blocksize or |
| 1268 | * smaller we get to the buffer by simple arithmetics. | 1345 | * smaller we get to the buffer by simple arithmetics. |
| @@ -1277,24 +1354,6 @@ xfs_imap( | |||
| 1277 | return 0; | 1354 | return 0; |
| 1278 | } | 1355 | } |
| 1279 | 1356 | ||
| 1280 | blks_per_cluster = XFS_INODE_CLUSTER_SIZE(mp) >> mp->m_sb.sb_blocklog; | ||
| 1281 | |||
| 1282 | /* | ||
| 1283 | * If we get a block number passed from bulkstat we can use it to | ||
| 1284 | * find the buffer easily. | ||
| 1285 | */ | ||
| 1286 | if (imap->im_blkno) { | ||
| 1287 | offset = XFS_INO_TO_OFFSET(mp, ino); | ||
| 1288 | ASSERT(offset < mp->m_sb.sb_inopblock); | ||
| 1289 | |||
| 1290 | cluster_agbno = xfs_daddr_to_agbno(mp, imap->im_blkno); | ||
| 1291 | offset += (agbno - cluster_agbno) * mp->m_sb.sb_inopblock; | ||
| 1292 | |||
| 1293 | imap->im_len = XFS_FSB_TO_BB(mp, blks_per_cluster); | ||
| 1294 | imap->im_boffset = (ushort)(offset << mp->m_sb.sb_inodelog); | ||
| 1295 | return 0; | ||
| 1296 | } | ||
| 1297 | |||
| 1298 | /* | 1357 | /* |
| 1299 | * If the inode chunks are aligned then use simple maths to | 1358 | * If the inode chunks are aligned then use simple maths to |
| 1300 | * find the location. Otherwise we have to do a btree | 1359 | * find the location. Otherwise we have to do a btree |
| @@ -1304,50 +1363,13 @@ xfs_imap( | |||
| 1304 | offset_agbno = agbno & mp->m_inoalign_mask; | 1363 | offset_agbno = agbno & mp->m_inoalign_mask; |
| 1305 | chunk_agbno = agbno - offset_agbno; | 1364 | chunk_agbno = agbno - offset_agbno; |
| 1306 | } else { | 1365 | } else { |
| 1307 | xfs_btree_cur_t *cur; /* inode btree cursor */ | 1366 | error = xfs_imap_lookup(mp, tp, agno, agino, agbno, |
| 1308 | xfs_inobt_rec_incore_t chunk_rec; | 1367 | &chunk_agbno, &offset_agbno, flags); |
| 1309 | xfs_buf_t *agbp; /* agi buffer */ | ||
| 1310 | int i; /* temp state */ | ||
| 1311 | |||
| 1312 | error = xfs_ialloc_read_agi(mp, tp, agno, &agbp); | ||
| 1313 | if (error) { | ||
| 1314 | xfs_fs_cmn_err(CE_ALERT, mp, "xfs_imap: " | ||
| 1315 | "xfs_ialloc_read_agi() returned " | ||
| 1316 | "error %d, agno %d", | ||
| 1317 | error, agno); | ||
| 1318 | return error; | ||
| 1319 | } | ||
| 1320 | |||
| 1321 | cur = xfs_inobt_init_cursor(mp, tp, agbp, agno); | ||
| 1322 | error = xfs_inobt_lookup(cur, agino, XFS_LOOKUP_LE, &i); | ||
| 1323 | if (error) { | ||
| 1324 | xfs_fs_cmn_err(CE_ALERT, mp, "xfs_imap: " | ||
| 1325 | "xfs_inobt_lookup() failed"); | ||
| 1326 | goto error0; | ||
| 1327 | } | ||
| 1328 | |||
| 1329 | error = xfs_inobt_get_rec(cur, &chunk_rec, &i); | ||
| 1330 | if (error) { | ||
| 1331 | xfs_fs_cmn_err(CE_ALERT, mp, "xfs_imap: " | ||
| 1332 | "xfs_inobt_get_rec() failed"); | ||
| 1333 | goto error0; | ||
| 1334 | } | ||
| 1335 | if (i == 0) { | ||
| 1336 | #ifdef DEBUG | ||
| 1337 | xfs_fs_cmn_err(CE_ALERT, mp, "xfs_imap: " | ||
| 1338 | "xfs_inobt_get_rec() failed"); | ||
| 1339 | #endif /* DEBUG */ | ||
| 1340 | error = XFS_ERROR(EINVAL); | ||
| 1341 | } | ||
| 1342 | error0: | ||
| 1343 | xfs_trans_brelse(tp, agbp); | ||
| 1344 | xfs_btree_del_cursor(cur, XFS_BTREE_NOERROR); | ||
| 1345 | if (error) | 1368 | if (error) |
| 1346 | return error; | 1369 | return error; |
| 1347 | chunk_agbno = XFS_AGINO_TO_AGBNO(mp, chunk_rec.ir_startino); | ||
| 1348 | offset_agbno = agbno - chunk_agbno; | ||
| 1349 | } | 1370 | } |
| 1350 | 1371 | ||
| 1372 | out_map: | ||
| 1351 | ASSERT(agbno >= chunk_agbno); | 1373 | ASSERT(agbno >= chunk_agbno); |
| 1352 | cluster_agbno = chunk_agbno + | 1374 | cluster_agbno = chunk_agbno + |
| 1353 | ((offset_agbno / blks_per_cluster) * blks_per_cluster); | 1375 | ((offset_agbno / blks_per_cluster) * blks_per_cluster); |
diff --git a/fs/xfs/xfs_iget.c b/fs/xfs/xfs_iget.c index 75df75f43d48..8f8b91be2c99 100644 --- a/fs/xfs/xfs_iget.c +++ b/fs/xfs/xfs_iget.c | |||
| @@ -259,7 +259,6 @@ xfs_iget_cache_miss( | |||
| 259 | xfs_trans_t *tp, | 259 | xfs_trans_t *tp, |
| 260 | xfs_ino_t ino, | 260 | xfs_ino_t ino, |
| 261 | struct xfs_inode **ipp, | 261 | struct xfs_inode **ipp, |
| 262 | xfs_daddr_t bno, | ||
| 263 | int flags, | 262 | int flags, |
| 264 | int lock_flags) | 263 | int lock_flags) |
| 265 | { | 264 | { |
| @@ -272,7 +271,7 @@ xfs_iget_cache_miss( | |||
| 272 | if (!ip) | 271 | if (!ip) |
| 273 | return ENOMEM; | 272 | return ENOMEM; |
| 274 | 273 | ||
| 275 | error = xfs_iread(mp, tp, ip, bno, flags); | 274 | error = xfs_iread(mp, tp, ip, flags); |
| 276 | if (error) | 275 | if (error) |
| 277 | goto out_destroy; | 276 | goto out_destroy; |
| 278 | 277 | ||
| @@ -358,8 +357,6 @@ out_destroy: | |||
| 358 | * within the file system for the inode being requested. | 357 | * within the file system for the inode being requested. |
| 359 | * lock_flags -- flags indicating how to lock the inode. See the comment | 358 | * lock_flags -- flags indicating how to lock the inode. See the comment |
| 360 | * for xfs_ilock() for a list of valid values. | 359 | * for xfs_ilock() for a list of valid values. |
| 361 | * bno -- the block number starting the buffer containing the inode, | ||
| 362 | * if known (as by bulkstat), else 0. | ||
| 363 | */ | 360 | */ |
| 364 | int | 361 | int |
| 365 | xfs_iget( | 362 | xfs_iget( |
| @@ -368,8 +365,7 @@ xfs_iget( | |||
| 368 | xfs_ino_t ino, | 365 | xfs_ino_t ino, |
| 369 | uint flags, | 366 | uint flags, |
| 370 | uint lock_flags, | 367 | uint lock_flags, |
| 371 | xfs_inode_t **ipp, | 368 | xfs_inode_t **ipp) |
| 372 | xfs_daddr_t bno) | ||
| 373 | { | 369 | { |
| 374 | xfs_inode_t *ip; | 370 | xfs_inode_t *ip; |
| 375 | int error; | 371 | int error; |
| @@ -397,7 +393,7 @@ again: | |||
| 397 | read_unlock(&pag->pag_ici_lock); | 393 | read_unlock(&pag->pag_ici_lock); |
| 398 | XFS_STATS_INC(xs_ig_missed); | 394 | XFS_STATS_INC(xs_ig_missed); |
| 399 | 395 | ||
| 400 | error = xfs_iget_cache_miss(mp, pag, tp, ino, &ip, bno, | 396 | error = xfs_iget_cache_miss(mp, pag, tp, ino, &ip, |
| 401 | flags, lock_flags); | 397 | flags, lock_flags); |
| 402 | if (error) | 398 | if (error) |
| 403 | goto out_error_or_again; | 399 | goto out_error_or_again; |
diff --git a/fs/xfs/xfs_inode.c b/fs/xfs/xfs_inode.c index d53c39de7d05..b76a829d7e20 100644 --- a/fs/xfs/xfs_inode.c +++ b/fs/xfs/xfs_inode.c | |||
| @@ -177,7 +177,7 @@ xfs_imap_to_bp( | |||
| 177 | if (unlikely(XFS_TEST_ERROR(!di_ok, mp, | 177 | if (unlikely(XFS_TEST_ERROR(!di_ok, mp, |
| 178 | XFS_ERRTAG_ITOBP_INOTOBP, | 178 | XFS_ERRTAG_ITOBP_INOTOBP, |
| 179 | XFS_RANDOM_ITOBP_INOTOBP))) { | 179 | XFS_RANDOM_ITOBP_INOTOBP))) { |
| 180 | if (iget_flags & XFS_IGET_BULKSTAT) { | 180 | if (iget_flags & XFS_IGET_UNTRUSTED) { |
| 181 | xfs_trans_brelse(tp, bp); | 181 | xfs_trans_brelse(tp, bp); |
| 182 | return XFS_ERROR(EINVAL); | 182 | return XFS_ERROR(EINVAL); |
| 183 | } | 183 | } |
| @@ -787,7 +787,6 @@ xfs_iread( | |||
| 787 | xfs_mount_t *mp, | 787 | xfs_mount_t *mp, |
| 788 | xfs_trans_t *tp, | 788 | xfs_trans_t *tp, |
| 789 | xfs_inode_t *ip, | 789 | xfs_inode_t *ip, |
| 790 | xfs_daddr_t bno, | ||
| 791 | uint iget_flags) | 790 | uint iget_flags) |
| 792 | { | 791 | { |
| 793 | xfs_buf_t *bp; | 792 | xfs_buf_t *bp; |
| @@ -797,11 +796,9 @@ xfs_iread( | |||
| 797 | /* | 796 | /* |
| 798 | * Fill in the location information in the in-core inode. | 797 | * Fill in the location information in the in-core inode. |
| 799 | */ | 798 | */ |
| 800 | ip->i_imap.im_blkno = bno; | ||
| 801 | error = xfs_imap(mp, tp, ip->i_ino, &ip->i_imap, iget_flags); | 799 | error = xfs_imap(mp, tp, ip->i_ino, &ip->i_imap, iget_flags); |
| 802 | if (error) | 800 | if (error) |
| 803 | return error; | 801 | return error; |
| 804 | ASSERT(bno == 0 || bno == ip->i_imap.im_blkno); | ||
| 805 | 802 | ||
| 806 | /* | 803 | /* |
| 807 | * Get pointers to the on-disk inode and the buffer containing it. | 804 | * Get pointers to the on-disk inode and the buffer containing it. |
diff --git a/fs/xfs/xfs_inode.h b/fs/xfs/xfs_inode.h index 9965e40a4615..78550df13cd6 100644 --- a/fs/xfs/xfs_inode.h +++ b/fs/xfs/xfs_inode.h | |||
| @@ -442,7 +442,7 @@ static inline void xfs_ifunlock(xfs_inode_t *ip) | |||
| 442 | * xfs_iget.c prototypes. | 442 | * xfs_iget.c prototypes. |
| 443 | */ | 443 | */ |
| 444 | int xfs_iget(struct xfs_mount *, struct xfs_trans *, xfs_ino_t, | 444 | int xfs_iget(struct xfs_mount *, struct xfs_trans *, xfs_ino_t, |
| 445 | uint, uint, xfs_inode_t **, xfs_daddr_t); | 445 | uint, uint, xfs_inode_t **); |
| 446 | void xfs_iput(xfs_inode_t *, uint); | 446 | void xfs_iput(xfs_inode_t *, uint); |
| 447 | void xfs_iput_new(xfs_inode_t *, uint); | 447 | void xfs_iput_new(xfs_inode_t *, uint); |
| 448 | void xfs_ilock(xfs_inode_t *, uint); | 448 | void xfs_ilock(xfs_inode_t *, uint); |
| @@ -500,7 +500,7 @@ do { \ | |||
| 500 | * Flags for xfs_iget() | 500 | * Flags for xfs_iget() |
| 501 | */ | 501 | */ |
| 502 | #define XFS_IGET_CREATE 0x1 | 502 | #define XFS_IGET_CREATE 0x1 |
| 503 | #define XFS_IGET_BULKSTAT 0x2 | 503 | #define XFS_IGET_UNTRUSTED 0x2 |
| 504 | 504 | ||
| 505 | int xfs_inotobp(struct xfs_mount *, struct xfs_trans *, | 505 | int xfs_inotobp(struct xfs_mount *, struct xfs_trans *, |
| 506 | xfs_ino_t, struct xfs_dinode **, | 506 | xfs_ino_t, struct xfs_dinode **, |
| @@ -509,7 +509,7 @@ int xfs_itobp(struct xfs_mount *, struct xfs_trans *, | |||
| 509 | struct xfs_inode *, struct xfs_dinode **, | 509 | struct xfs_inode *, struct xfs_dinode **, |
| 510 | struct xfs_buf **, uint); | 510 | struct xfs_buf **, uint); |
| 511 | int xfs_iread(struct xfs_mount *, struct xfs_trans *, | 511 | int xfs_iread(struct xfs_mount *, struct xfs_trans *, |
| 512 | struct xfs_inode *, xfs_daddr_t, uint); | 512 | struct xfs_inode *, uint); |
| 513 | void xfs_dinode_to_disk(struct xfs_dinode *, | 513 | void xfs_dinode_to_disk(struct xfs_dinode *, |
| 514 | struct xfs_icdinode *); | 514 | struct xfs_icdinode *); |
| 515 | void xfs_idestroy_fork(struct xfs_inode *, int); | 515 | void xfs_idestroy_fork(struct xfs_inode *, int); |
diff --git a/fs/xfs/xfs_itable.c b/fs/xfs/xfs_itable.c index b1b801e4a28e..2b86f8610512 100644 --- a/fs/xfs/xfs_itable.c +++ b/fs/xfs/xfs_itable.c | |||
| @@ -49,24 +49,40 @@ xfs_internal_inum( | |||
| 49 | (ino == mp->m_sb.sb_uquotino || ino == mp->m_sb.sb_gquotino))); | 49 | (ino == mp->m_sb.sb_uquotino || ino == mp->m_sb.sb_gquotino))); |
| 50 | } | 50 | } |
| 51 | 51 | ||
| 52 | STATIC int | 52 | /* |
| 53 | xfs_bulkstat_one_iget( | 53 | * Return stat information for one inode. |
| 54 | xfs_mount_t *mp, /* mount point for filesystem */ | 54 | * Return 0 if ok, else errno. |
| 55 | xfs_ino_t ino, /* inode number to get data for */ | 55 | */ |
| 56 | xfs_daddr_t bno, /* starting bno of inode cluster */ | 56 | int |
| 57 | xfs_bstat_t *buf, /* return buffer */ | 57 | xfs_bulkstat_one_int( |
| 58 | int *stat) /* BULKSTAT_RV_... */ | 58 | struct xfs_mount *mp, /* mount point for filesystem */ |
| 59 | xfs_ino_t ino, /* inode to get data for */ | ||
| 60 | void __user *buffer, /* buffer to place output in */ | ||
| 61 | int ubsize, /* size of buffer */ | ||
| 62 | bulkstat_one_fmt_pf formatter, /* formatter, copy to user */ | ||
| 63 | int *ubused, /* bytes used by me */ | ||
| 64 | int *stat) /* BULKSTAT_RV_... */ | ||
| 59 | { | 65 | { |
| 60 | xfs_icdinode_t *dic; /* dinode core info pointer */ | 66 | struct xfs_icdinode *dic; /* dinode core info pointer */ |
| 61 | xfs_inode_t *ip; /* incore inode pointer */ | 67 | struct xfs_inode *ip; /* incore inode pointer */ |
| 62 | struct inode *inode; | 68 | struct inode *inode; |
| 63 | int error; | 69 | struct xfs_bstat *buf; /* return buffer */ |
| 70 | int error = 0; /* error value */ | ||
| 71 | |||
| 72 | *stat = BULKSTAT_RV_NOTHING; | ||
| 73 | |||
| 74 | if (!buffer || xfs_internal_inum(mp, ino)) | ||
| 75 | return XFS_ERROR(EINVAL); | ||
| 76 | |||
| 77 | buf = kmem_alloc(sizeof(*buf), KM_SLEEP | KM_MAYFAIL); | ||
| 78 | if (!buf) | ||
| 79 | return XFS_ERROR(ENOMEM); | ||
| 64 | 80 | ||
| 65 | error = xfs_iget(mp, NULL, ino, | 81 | error = xfs_iget(mp, NULL, ino, |
| 66 | XFS_IGET_BULKSTAT, XFS_ILOCK_SHARED, &ip, bno); | 82 | XFS_IGET_UNTRUSTED, XFS_ILOCK_SHARED, &ip); |
| 67 | if (error) { | 83 | if (error) { |
| 68 | *stat = BULKSTAT_RV_NOTHING; | 84 | *stat = BULKSTAT_RV_NOTHING; |
| 69 | return error; | 85 | goto out_free; |
| 70 | } | 86 | } |
| 71 | 87 | ||
| 72 | ASSERT(ip != NULL); | 88 | ASSERT(ip != NULL); |
| @@ -127,77 +143,16 @@ xfs_bulkstat_one_iget( | |||
| 127 | buf->bs_blocks = dic->di_nblocks + ip->i_delayed_blks; | 143 | buf->bs_blocks = dic->di_nblocks + ip->i_delayed_blks; |
| 128 | break; | 144 | break; |
| 129 | } | 145 | } |
| 130 | |||
| 131 | xfs_iput(ip, XFS_ILOCK_SHARED); | 146 | xfs_iput(ip, XFS_ILOCK_SHARED); |
| 132 | return error; | ||
| 133 | } | ||
| 134 | 147 | ||
| 135 | STATIC void | 148 | error = formatter(buffer, ubsize, ubused, buf); |
| 136 | xfs_bulkstat_one_dinode( | ||
| 137 | xfs_mount_t *mp, /* mount point for filesystem */ | ||
| 138 | xfs_ino_t ino, /* inode number to get data for */ | ||
| 139 | xfs_dinode_t *dic, /* dinode inode pointer */ | ||
| 140 | xfs_bstat_t *buf) /* return buffer */ | ||
| 141 | { | ||
| 142 | /* | ||
| 143 | * The inode format changed when we moved the link count and | ||
| 144 | * made it 32 bits long. If this is an old format inode, | ||
| 145 | * convert it in memory to look like a new one. If it gets | ||
| 146 | * flushed to disk we will convert back before flushing or | ||
| 147 | * logging it. We zero out the new projid field and the old link | ||
| 148 | * count field. We'll handle clearing the pad field (the remains | ||
| 149 | * of the old uuid field) when we actually convert the inode to | ||
| 150 | * the new format. We don't change the version number so that we | ||
| 151 | * can distinguish this from a real new format inode. | ||
| 152 | */ | ||
| 153 | if (dic->di_version == 1) { | ||
| 154 | buf->bs_nlink = be16_to_cpu(dic->di_onlink); | ||
| 155 | buf->bs_projid = 0; | ||
| 156 | } else { | ||
| 157 | buf->bs_nlink = be32_to_cpu(dic->di_nlink); | ||
| 158 | buf->bs_projid = be16_to_cpu(dic->di_projid); | ||
| 159 | } | ||
| 160 | 149 | ||
| 161 | buf->bs_ino = ino; | 150 | if (!error) |
| 162 | buf->bs_mode = be16_to_cpu(dic->di_mode); | 151 | *stat = BULKSTAT_RV_DIDONE; |
| 163 | buf->bs_uid = be32_to_cpu(dic->di_uid); | ||
| 164 | buf->bs_gid = be32_to_cpu(dic->di_gid); | ||
| 165 | buf->bs_size = be64_to_cpu(dic->di_size); | ||
| 166 | buf->bs_atime.tv_sec = be32_to_cpu(dic->di_atime.t_sec); | ||
| 167 | buf->bs_atime.tv_nsec = be32_to_cpu(dic->di_atime.t_nsec); | ||
| 168 | buf->bs_mtime.tv_sec = be32_to_cpu(dic->di_mtime.t_sec); | ||
| 169 | buf->bs_mtime.tv_nsec = be32_to_cpu(dic->di_mtime.t_nsec); | ||
| 170 | buf->bs_ctime.tv_sec = be32_to_cpu(dic->di_ctime.t_sec); | ||
| 171 | buf->bs_ctime.tv_nsec = be32_to_cpu(dic->di_ctime.t_nsec); | ||
| 172 | buf->bs_xflags = xfs_dic2xflags(dic); | ||
| 173 | buf->bs_extsize = be32_to_cpu(dic->di_extsize) << mp->m_sb.sb_blocklog; | ||
| 174 | buf->bs_extents = be32_to_cpu(dic->di_nextents); | ||
| 175 | buf->bs_gen = be32_to_cpu(dic->di_gen); | ||
| 176 | memset(buf->bs_pad, 0, sizeof(buf->bs_pad)); | ||
| 177 | buf->bs_dmevmask = be32_to_cpu(dic->di_dmevmask); | ||
| 178 | buf->bs_dmstate = be16_to_cpu(dic->di_dmstate); | ||
| 179 | buf->bs_aextents = be16_to_cpu(dic->di_anextents); | ||
| 180 | buf->bs_forkoff = XFS_DFORK_BOFF(dic); | ||
| 181 | 152 | ||
| 182 | switch (dic->di_format) { | 153 | out_free: |
| 183 | case XFS_DINODE_FMT_DEV: | 154 | kmem_free(buf); |
| 184 | buf->bs_rdev = xfs_dinode_get_rdev(dic); | 155 | return error; |
| 185 | buf->bs_blksize = BLKDEV_IOSIZE; | ||
| 186 | buf->bs_blocks = 0; | ||
| 187 | break; | ||
| 188 | case XFS_DINODE_FMT_LOCAL: | ||
| 189 | case XFS_DINODE_FMT_UUID: | ||
| 190 | buf->bs_rdev = 0; | ||
| 191 | buf->bs_blksize = mp->m_sb.sb_blocksize; | ||
| 192 | buf->bs_blocks = 0; | ||
| 193 | break; | ||
| 194 | case XFS_DINODE_FMT_EXTENTS: | ||
| 195 | case XFS_DINODE_FMT_BTREE: | ||
| 196 | buf->bs_rdev = 0; | ||
| 197 | buf->bs_blksize = mp->m_sb.sb_blocksize; | ||
| 198 | buf->bs_blocks = be64_to_cpu(dic->di_nblocks); | ||
| 199 | break; | ||
| 200 | } | ||
| 201 | } | 156 | } |
| 202 | 157 | ||
| 203 | /* Return 0 on success or positive error */ | 158 | /* Return 0 on success or positive error */ |
| @@ -217,118 +172,17 @@ xfs_bulkstat_one_fmt( | |||
| 217 | return 0; | 172 | return 0; |
| 218 | } | 173 | } |
| 219 | 174 | ||
| 220 | /* | ||
| 221 | * Return stat information for one inode. | ||
| 222 | * Return 0 if ok, else errno. | ||
| 223 | */ | ||
| 224 | int /* error status */ | ||
| 225 | xfs_bulkstat_one_int( | ||
| 226 | xfs_mount_t *mp, /* mount point for filesystem */ | ||
| 227 | xfs_ino_t ino, /* inode number to get data for */ | ||
| 228 | void __user *buffer, /* buffer to place output in */ | ||
| 229 | int ubsize, /* size of buffer */ | ||
| 230 | bulkstat_one_fmt_pf formatter, /* formatter, copy to user */ | ||
| 231 | xfs_daddr_t bno, /* starting bno of inode cluster */ | ||
| 232 | int *ubused, /* bytes used by me */ | ||
| 233 | void *dibuff, /* on-disk inode buffer */ | ||
| 234 | int *stat) /* BULKSTAT_RV_... */ | ||
| 235 | { | ||
| 236 | xfs_bstat_t *buf; /* return buffer */ | ||
| 237 | int error = 0; /* error value */ | ||
| 238 | xfs_dinode_t *dip; /* dinode inode pointer */ | ||
| 239 | |||
| 240 | dip = (xfs_dinode_t *)dibuff; | ||
| 241 | *stat = BULKSTAT_RV_NOTHING; | ||
| 242 | |||
| 243 | if (!buffer || xfs_internal_inum(mp, ino)) | ||
| 244 | return XFS_ERROR(EINVAL); | ||
| 245 | |||
| 246 | buf = kmem_alloc(sizeof(*buf), KM_SLEEP); | ||
| 247 | |||
| 248 | if (dip == NULL) { | ||
| 249 | /* We're not being passed a pointer to a dinode. This happens | ||
| 250 | * if BULKSTAT_FG_IGET is selected. Do the iget. | ||
| 251 | */ | ||
| 252 | error = xfs_bulkstat_one_iget(mp, ino, bno, buf, stat); | ||
| 253 | if (error) | ||
| 254 | goto out_free; | ||
| 255 | } else { | ||
| 256 | xfs_bulkstat_one_dinode(mp, ino, dip, buf); | ||
| 257 | } | ||
| 258 | |||
| 259 | error = formatter(buffer, ubsize, ubused, buf); | ||
| 260 | if (error) | ||
| 261 | goto out_free; | ||
| 262 | |||
| 263 | *stat = BULKSTAT_RV_DIDONE; | ||
| 264 | |||
| 265 | out_free: | ||
| 266 | kmem_free(buf); | ||
| 267 | return error; | ||
| 268 | } | ||
| 269 | |||
| 270 | int | 175 | int |
| 271 | xfs_bulkstat_one( | 176 | xfs_bulkstat_one( |
| 272 | xfs_mount_t *mp, /* mount point for filesystem */ | 177 | xfs_mount_t *mp, /* mount point for filesystem */ |
| 273 | xfs_ino_t ino, /* inode number to get data for */ | 178 | xfs_ino_t ino, /* inode number to get data for */ |
| 274 | void __user *buffer, /* buffer to place output in */ | 179 | void __user *buffer, /* buffer to place output in */ |
| 275 | int ubsize, /* size of buffer */ | 180 | int ubsize, /* size of buffer */ |
| 276 | void *private_data, /* my private data */ | ||
| 277 | xfs_daddr_t bno, /* starting bno of inode cluster */ | ||
| 278 | int *ubused, /* bytes used by me */ | 181 | int *ubused, /* bytes used by me */ |
| 279 | void *dibuff, /* on-disk inode buffer */ | ||
| 280 | int *stat) /* BULKSTAT_RV_... */ | 182 | int *stat) /* BULKSTAT_RV_... */ |
| 281 | { | 183 | { |
| 282 | return xfs_bulkstat_one_int(mp, ino, buffer, ubsize, | 184 | return xfs_bulkstat_one_int(mp, ino, buffer, ubsize, |
| 283 | xfs_bulkstat_one_fmt, bno, | 185 | xfs_bulkstat_one_fmt, ubused, stat); |
| 284 | ubused, dibuff, stat); | ||
| 285 | } | ||
| 286 | |||
| 287 | /* | ||
| 288 | * Test to see whether we can use the ondisk inode directly, based | ||
| 289 | * on the given bulkstat flags, filling in dipp accordingly. | ||
| 290 | * Returns zero if the inode is dodgey. | ||
| 291 | */ | ||
| 292 | STATIC int | ||
| 293 | xfs_bulkstat_use_dinode( | ||
| 294 | xfs_mount_t *mp, | ||
| 295 | int flags, | ||
| 296 | xfs_buf_t *bp, | ||
| 297 | int clustidx, | ||
| 298 | xfs_dinode_t **dipp) | ||
| 299 | { | ||
| 300 | xfs_dinode_t *dip; | ||
| 301 | unsigned int aformat; | ||
| 302 | |||
| 303 | *dipp = NULL; | ||
| 304 | if (!bp || (flags & BULKSTAT_FG_IGET)) | ||
| 305 | return 1; | ||
| 306 | dip = (xfs_dinode_t *) | ||
| 307 | xfs_buf_offset(bp, clustidx << mp->m_sb.sb_inodelog); | ||
| 308 | /* | ||
| 309 | * Check the buffer containing the on-disk inode for di_mode == 0. | ||
| 310 | * This is to prevent xfs_bulkstat from picking up just reclaimed | ||
| 311 | * inodes that have their in-core state initialized but not flushed | ||
| 312 | * to disk yet. This is a temporary hack that would require a proper | ||
| 313 | * fix in the future. | ||
| 314 | */ | ||
| 315 | if (be16_to_cpu(dip->di_magic) != XFS_DINODE_MAGIC || | ||
| 316 | !XFS_DINODE_GOOD_VERSION(dip->di_version) || | ||
| 317 | !dip->di_mode) | ||
| 318 | return 0; | ||
| 319 | if (flags & BULKSTAT_FG_QUICK) { | ||
| 320 | *dipp = dip; | ||
| 321 | return 1; | ||
| 322 | } | ||
| 323 | /* BULKSTAT_FG_INLINE: if attr fork is local, or not there, use it */ | ||
| 324 | aformat = dip->di_aformat; | ||
| 325 | if ((XFS_DFORK_Q(dip) == 0) || | ||
| 326 | (aformat == XFS_DINODE_FMT_LOCAL) || | ||
| 327 | (aformat == XFS_DINODE_FMT_EXTENTS && !dip->di_anextents)) { | ||
| 328 | *dipp = dip; | ||
| 329 | return 1; | ||
| 330 | } | ||
| 331 | return 1; | ||
| 332 | } | 186 | } |
| 333 | 187 | ||
| 334 | #define XFS_BULKSTAT_UBLEFT(ubleft) ((ubleft) >= statstruct_size) | 188 | #define XFS_BULKSTAT_UBLEFT(ubleft) ((ubleft) >= statstruct_size) |
| @@ -342,10 +196,8 @@ xfs_bulkstat( | |||
| 342 | xfs_ino_t *lastinop, /* last inode returned */ | 196 | xfs_ino_t *lastinop, /* last inode returned */ |
| 343 | int *ubcountp, /* size of buffer/count returned */ | 197 | int *ubcountp, /* size of buffer/count returned */ |
| 344 | bulkstat_one_pf formatter, /* func that'd fill a single buf */ | 198 | bulkstat_one_pf formatter, /* func that'd fill a single buf */ |
| 345 | void *private_data,/* private data for formatter */ | ||
| 346 | size_t statstruct_size, /* sizeof struct filling */ | 199 | size_t statstruct_size, /* sizeof struct filling */ |
| 347 | char __user *ubuffer, /* buffer with inode stats */ | 200 | char __user *ubuffer, /* buffer with inode stats */ |
| 348 | int flags, /* defined in xfs_itable.h */ | ||
| 349 | int *done) /* 1 if there are more stats to get */ | 201 | int *done) /* 1 if there are more stats to get */ |
| 350 | { | 202 | { |
| 351 | xfs_agblock_t agbno=0;/* allocation group block number */ | 203 | xfs_agblock_t agbno=0;/* allocation group block number */ |
| @@ -380,14 +232,12 @@ xfs_bulkstat( | |||
| 380 | int ubelem; /* spaces used in user's buffer */ | 232 | int ubelem; /* spaces used in user's buffer */ |
| 381 | int ubused; /* bytes used by formatter */ | 233 | int ubused; /* bytes used by formatter */ |
| 382 | xfs_buf_t *bp; /* ptr to on-disk inode cluster buf */ | 234 | xfs_buf_t *bp; /* ptr to on-disk inode cluster buf */ |
| 383 | xfs_dinode_t *dip; /* ptr into bp for specific inode */ | ||
| 384 | 235 | ||
| 385 | /* | 236 | /* |
| 386 | * Get the last inode value, see if there's nothing to do. | 237 | * Get the last inode value, see if there's nothing to do. |
| 387 | */ | 238 | */ |
| 388 | ino = (xfs_ino_t)*lastinop; | 239 | ino = (xfs_ino_t)*lastinop; |
| 389 | lastino = ino; | 240 | lastino = ino; |
| 390 | dip = NULL; | ||
| 391 | agno = XFS_INO_TO_AGNO(mp, ino); | 241 | agno = XFS_INO_TO_AGNO(mp, ino); |
| 392 | agino = XFS_INO_TO_AGINO(mp, ino); | 242 | agino = XFS_INO_TO_AGINO(mp, ino); |
| 393 | if (agno >= mp->m_sb.sb_agcount || | 243 | if (agno >= mp->m_sb.sb_agcount || |
| @@ -612,37 +462,6 @@ xfs_bulkstat( | |||
| 612 | irbp->ir_startino) + | 462 | irbp->ir_startino) + |
| 613 | ((chunkidx & nimask) >> | 463 | ((chunkidx & nimask) >> |
| 614 | mp->m_sb.sb_inopblog); | 464 | mp->m_sb.sb_inopblog); |
| 615 | |||
| 616 | if (flags & (BULKSTAT_FG_QUICK | | ||
| 617 | BULKSTAT_FG_INLINE)) { | ||
| 618 | int offset; | ||
| 619 | |||
| 620 | ino = XFS_AGINO_TO_INO(mp, agno, | ||
| 621 | agino); | ||
| 622 | bno = XFS_AGB_TO_DADDR(mp, agno, | ||
| 623 | agbno); | ||
| 624 | |||
| 625 | /* | ||
| 626 | * Get the inode cluster buffer | ||
| 627 | */ | ||
| 628 | if (bp) | ||
| 629 | xfs_buf_relse(bp); | ||
| 630 | |||
| 631 | error = xfs_inotobp(mp, NULL, ino, &dip, | ||
| 632 | &bp, &offset, | ||
| 633 | XFS_IGET_BULKSTAT); | ||
| 634 | |||
| 635 | if (!error) | ||
| 636 | clustidx = offset / mp->m_sb.sb_inodesize; | ||
| 637 | if (XFS_TEST_ERROR(error != 0, | ||
| 638 | mp, XFS_ERRTAG_BULKSTAT_READ_CHUNK, | ||
| 639 | XFS_RANDOM_BULKSTAT_READ_CHUNK)) { | ||
| 640 | bp = NULL; | ||
| 641 | ubleft = 0; | ||
| 642 | rval = error; | ||
| 643 | break; | ||
| 644 | } | ||
| 645 | } | ||
| 646 | } | 465 | } |
| 647 | ino = XFS_AGINO_TO_INO(mp, agno, agino); | 466 | ino = XFS_AGINO_TO_INO(mp, agno, agino); |
| 648 | bno = XFS_AGB_TO_DADDR(mp, agno, agbno); | 467 | bno = XFS_AGB_TO_DADDR(mp, agno, agbno); |
| @@ -658,35 +477,13 @@ xfs_bulkstat( | |||
| 658 | * when the chunk is used up. | 477 | * when the chunk is used up. |
| 659 | */ | 478 | */ |
| 660 | irbp->ir_freecount++; | 479 | irbp->ir_freecount++; |
| 661 | if (!xfs_bulkstat_use_dinode(mp, flags, bp, | ||
| 662 | clustidx, &dip)) { | ||
| 663 | lastino = ino; | ||
| 664 | continue; | ||
| 665 | } | ||
| 666 | /* | ||
| 667 | * If we need to do an iget, cannot hold bp. | ||
| 668 | * Drop it, until starting the next cluster. | ||
| 669 | */ | ||
| 670 | if ((flags & BULKSTAT_FG_INLINE) && !dip) { | ||
| 671 | if (bp) | ||
| 672 | xfs_buf_relse(bp); | ||
| 673 | bp = NULL; | ||
| 674 | } | ||
| 675 | 480 | ||
| 676 | /* | 481 | /* |
| 677 | * Get the inode and fill in a single buffer. | 482 | * Get the inode and fill in a single buffer. |
| 678 | * BULKSTAT_FG_QUICK uses dip to fill it in. | ||
| 679 | * BULKSTAT_FG_IGET uses igets. | ||
| 680 | * BULKSTAT_FG_INLINE uses dip if we have an | ||
| 681 | * inline attr fork, else igets. | ||
| 682 | * See: xfs_bulkstat_one & xfs_dm_bulkstat_one. | ||
| 683 | * This is also used to count inodes/blks, etc | ||
| 684 | * in xfs_qm_quotacheck. | ||
| 685 | */ | 483 | */ |
| 686 | ubused = statstruct_size; | 484 | ubused = statstruct_size; |
| 687 | error = formatter(mp, ino, ubufp, | 485 | error = formatter(mp, ino, ubufp, ubleft, |
| 688 | ubleft, private_data, | 486 | &ubused, &fmterror); |
| 689 | bno, &ubused, dip, &fmterror); | ||
| 690 | if (fmterror == BULKSTAT_RV_NOTHING) { | 487 | if (fmterror == BULKSTAT_RV_NOTHING) { |
| 691 | if (error && error != ENOENT && | 488 | if (error && error != ENOENT && |
| 692 | error != EINVAL) { | 489 | error != EINVAL) { |
| @@ -778,8 +575,7 @@ xfs_bulkstat_single( | |||
| 778 | */ | 575 | */ |
| 779 | 576 | ||
| 780 | ino = (xfs_ino_t)*lastinop; | 577 | ino = (xfs_ino_t)*lastinop; |
| 781 | error = xfs_bulkstat_one(mp, ino, buffer, sizeof(xfs_bstat_t), | 578 | error = xfs_bulkstat_one(mp, ino, buffer, sizeof(xfs_bstat_t), 0, &res); |
| 782 | NULL, 0, NULL, NULL, &res); | ||
| 783 | if (error) { | 579 | if (error) { |
| 784 | /* | 580 | /* |
| 785 | * Special case way failed, do it the "long" way | 581 | * Special case way failed, do it the "long" way |
| @@ -788,8 +584,7 @@ xfs_bulkstat_single( | |||
| 788 | (*lastinop)--; | 584 | (*lastinop)--; |
| 789 | count = 1; | 585 | count = 1; |
| 790 | if (xfs_bulkstat(mp, lastinop, &count, xfs_bulkstat_one, | 586 | if (xfs_bulkstat(mp, lastinop, &count, xfs_bulkstat_one, |
| 791 | NULL, sizeof(xfs_bstat_t), buffer, | 587 | sizeof(xfs_bstat_t), buffer, done)) |
| 792 | BULKSTAT_FG_IGET, done)) | ||
| 793 | return error; | 588 | return error; |
| 794 | if (count == 0 || (xfs_ino_t)*lastinop != ino) | 589 | if (count == 0 || (xfs_ino_t)*lastinop != ino) |
| 795 | return error == EFSCORRUPTED ? | 590 | return error == EFSCORRUPTED ? |
diff --git a/fs/xfs/xfs_itable.h b/fs/xfs/xfs_itable.h index 20792bf45946..97295d91d170 100644 --- a/fs/xfs/xfs_itable.h +++ b/fs/xfs/xfs_itable.h | |||
| @@ -27,10 +27,7 @@ typedef int (*bulkstat_one_pf)(struct xfs_mount *mp, | |||
| 27 | xfs_ino_t ino, | 27 | xfs_ino_t ino, |
| 28 | void __user *buffer, | 28 | void __user *buffer, |
| 29 | int ubsize, | 29 | int ubsize, |
| 30 | void *private_data, | ||
| 31 | xfs_daddr_t bno, | ||
| 32 | int *ubused, | 30 | int *ubused, |
| 33 | void *dip, | ||
| 34 | int *stat); | 31 | int *stat); |
| 35 | 32 | ||
| 36 | /* | 33 | /* |
| @@ -41,13 +38,6 @@ typedef int (*bulkstat_one_pf)(struct xfs_mount *mp, | |||
| 41 | #define BULKSTAT_RV_GIVEUP 2 | 38 | #define BULKSTAT_RV_GIVEUP 2 |
| 42 | 39 | ||
| 43 | /* | 40 | /* |
| 44 | * Values for bulkstat flag argument. | ||
| 45 | */ | ||
| 46 | #define BULKSTAT_FG_IGET 0x1 /* Go through the buffer cache */ | ||
| 47 | #define BULKSTAT_FG_QUICK 0x2 /* No iget, walk the dinode cluster */ | ||
| 48 | #define BULKSTAT_FG_INLINE 0x4 /* No iget if inline attrs */ | ||
| 49 | |||
| 50 | /* | ||
| 51 | * Return stat information in bulk (by-inode) for the filesystem. | 41 | * Return stat information in bulk (by-inode) for the filesystem. |
| 52 | */ | 42 | */ |
| 53 | int /* error status */ | 43 | int /* error status */ |
| @@ -56,10 +46,8 @@ xfs_bulkstat( | |||
| 56 | xfs_ino_t *lastino, /* last inode returned */ | 46 | xfs_ino_t *lastino, /* last inode returned */ |
| 57 | int *count, /* size of buffer/count returned */ | 47 | int *count, /* size of buffer/count returned */ |
| 58 | bulkstat_one_pf formatter, /* func that'd fill a single buf */ | 48 | bulkstat_one_pf formatter, /* func that'd fill a single buf */ |
| 59 | void *private_data, /* private data for formatter */ | ||
| 60 | size_t statstruct_size,/* sizeof struct that we're filling */ | 49 | size_t statstruct_size,/* sizeof struct that we're filling */ |
| 61 | char __user *ubuffer,/* buffer with inode stats */ | 50 | char __user *ubuffer,/* buffer with inode stats */ |
| 62 | int flags, /* flag to control access method */ | ||
| 63 | int *done); /* 1 if there are more stats to get */ | 51 | int *done); /* 1 if there are more stats to get */ |
| 64 | 52 | ||
| 65 | int | 53 | int |
| @@ -82,9 +70,7 @@ xfs_bulkstat_one_int( | |||
| 82 | void __user *buffer, | 70 | void __user *buffer, |
| 83 | int ubsize, | 71 | int ubsize, |
| 84 | bulkstat_one_fmt_pf formatter, | 72 | bulkstat_one_fmt_pf formatter, |
| 85 | xfs_daddr_t bno, | ||
| 86 | int *ubused, | 73 | int *ubused, |
| 87 | void *dibuff, | ||
| 88 | int *stat); | 74 | int *stat); |
| 89 | 75 | ||
| 90 | int | 76 | int |
| @@ -93,10 +79,7 @@ xfs_bulkstat_one( | |||
| 93 | xfs_ino_t ino, | 79 | xfs_ino_t ino, |
| 94 | void __user *buffer, | 80 | void __user *buffer, |
| 95 | int ubsize, | 81 | int ubsize, |
| 96 | void *private_data, | ||
| 97 | xfs_daddr_t bno, | ||
| 98 | int *ubused, | 82 | int *ubused, |
| 99 | void *dibuff, | ||
| 100 | int *stat); | 83 | int *stat); |
| 101 | 84 | ||
| 102 | typedef int (*inumbers_fmt_pf)( | 85 | typedef int (*inumbers_fmt_pf)( |
diff --git a/fs/xfs/xfs_log_recover.c b/fs/xfs/xfs_log_recover.c index ed0684cc50ee..9ac5cfab27b9 100644 --- a/fs/xfs/xfs_log_recover.c +++ b/fs/xfs/xfs_log_recover.c | |||
| @@ -3198,7 +3198,7 @@ xlog_recover_process_one_iunlink( | |||
| 3198 | int error; | 3198 | int error; |
| 3199 | 3199 | ||
| 3200 | ino = XFS_AGINO_TO_INO(mp, agno, agino); | 3200 | ino = XFS_AGINO_TO_INO(mp, agno, agino); |
| 3201 | error = xfs_iget(mp, NULL, ino, 0, 0, &ip, 0); | 3201 | error = xfs_iget(mp, NULL, ino, 0, 0, &ip); |
| 3202 | if (error) | 3202 | if (error) |
| 3203 | goto fail; | 3203 | goto fail; |
| 3204 | 3204 | ||
diff --git a/fs/xfs/xfs_mount.c b/fs/xfs/xfs_mount.c index d59f4e8bedcf..69f62d8b2816 100644 --- a/fs/xfs/xfs_mount.c +++ b/fs/xfs/xfs_mount.c | |||
| @@ -1300,7 +1300,7 @@ xfs_mountfs( | |||
| 1300 | * Get and sanity-check the root inode. | 1300 | * Get and sanity-check the root inode. |
| 1301 | * Save the pointer to it in the mount structure. | 1301 | * Save the pointer to it in the mount structure. |
| 1302 | */ | 1302 | */ |
| 1303 | error = xfs_iget(mp, NULL, sbp->sb_rootino, 0, XFS_ILOCK_EXCL, &rip, 0); | 1303 | error = xfs_iget(mp, NULL, sbp->sb_rootino, 0, XFS_ILOCK_EXCL, &rip); |
| 1304 | if (error) { | 1304 | if (error) { |
| 1305 | cmn_err(CE_WARN, "XFS: failed to read root inode"); | 1305 | cmn_err(CE_WARN, "XFS: failed to read root inode"); |
| 1306 | goto out_log_dealloc; | 1306 | goto out_log_dealloc; |
diff --git a/fs/xfs/xfs_rtalloc.c b/fs/xfs/xfs_rtalloc.c index 16445518506d..a2d32ce335aa 100644 --- a/fs/xfs/xfs_rtalloc.c +++ b/fs/xfs/xfs_rtalloc.c | |||
| @@ -2277,12 +2277,12 @@ xfs_rtmount_inodes( | |||
| 2277 | sbp = &mp->m_sb; | 2277 | sbp = &mp->m_sb; |
| 2278 | if (sbp->sb_rbmino == NULLFSINO) | 2278 | if (sbp->sb_rbmino == NULLFSINO) |
| 2279 | return 0; | 2279 | return 0; |
| 2280 | error = xfs_iget(mp, NULL, sbp->sb_rbmino, 0, 0, &mp->m_rbmip, 0); | 2280 | error = xfs_iget(mp, NULL, sbp->sb_rbmino, 0, 0, &mp->m_rbmip); |
| 2281 | if (error) | 2281 | if (error) |
| 2282 | return error; | 2282 | return error; |
| 2283 | ASSERT(mp->m_rbmip != NULL); | 2283 | ASSERT(mp->m_rbmip != NULL); |
| 2284 | ASSERT(sbp->sb_rsumino != NULLFSINO); | 2284 | ASSERT(sbp->sb_rsumino != NULLFSINO); |
| 2285 | error = xfs_iget(mp, NULL, sbp->sb_rsumino, 0, 0, &mp->m_rsumip, 0); | 2285 | error = xfs_iget(mp, NULL, sbp->sb_rsumino, 0, 0, &mp->m_rsumip); |
| 2286 | if (error) { | 2286 | if (error) { |
| 2287 | IRELE(mp->m_rbmip); | 2287 | IRELE(mp->m_rbmip); |
| 2288 | return error; | 2288 | return error; |
diff --git a/fs/xfs/xfs_trans_inode.c b/fs/xfs/xfs_trans_inode.c index 785ff101da0a..2559dfec946b 100644 --- a/fs/xfs/xfs_trans_inode.c +++ b/fs/xfs/xfs_trans_inode.c | |||
| @@ -62,7 +62,7 @@ xfs_trans_iget( | |||
| 62 | { | 62 | { |
| 63 | int error; | 63 | int error; |
| 64 | 64 | ||
| 65 | error = xfs_iget(mp, tp, ino, flags, lock_flags, ipp, 0); | 65 | error = xfs_iget(mp, tp, ino, flags, lock_flags, ipp); |
| 66 | if (!error && tp) | 66 | if (!error && tp) |
| 67 | xfs_trans_ijoin(tp, *ipp, lock_flags); | 67 | xfs_trans_ijoin(tp, *ipp, lock_flags); |
| 68 | return error; | 68 | return error; |
diff --git a/fs/xfs/xfs_vnodeops.c b/fs/xfs/xfs_vnodeops.c index a06bd62504fc..c1646838898f 100644 --- a/fs/xfs/xfs_vnodeops.c +++ b/fs/xfs/xfs_vnodeops.c | |||
| @@ -1269,7 +1269,7 @@ xfs_lookup( | |||
| 1269 | if (error) | 1269 | if (error) |
| 1270 | goto out; | 1270 | goto out; |
| 1271 | 1271 | ||
| 1272 | error = xfs_iget(dp->i_mount, NULL, inum, 0, 0, ipp, 0); | 1272 | error = xfs_iget(dp->i_mount, NULL, inum, 0, 0, ipp); |
| 1273 | if (error) | 1273 | if (error) |
| 1274 | goto out_free_name; | 1274 | goto out_free_name; |
| 1275 | 1275 | ||
