fs/cifs/cifsfs.c

   1 /*
   2  *   fs/cifs/cifsfs.c
   3  *
   4  *   Copyright (C) International Business Machines  Corp., 2002,2007
   5  *   Author(s): Steve French (sfrench@us.ibm.com)
   6  *
   7  *   Common Internet FileSystem (CIFS) client
   8  *
   9  *   This library is free software; you can redistribute it and/or modify
  10  *   it under the terms of the GNU Lesser General Public License as published
  11  *   by the Free Software Foundation; either version 2.1 of the License, or
  12  *   (at your option) any later version.
  13  *
  14  *   This library is distributed in the hope that it will be useful,
  15  *   but WITHOUT ANY WARRANTY; without even the implied warranty of
  16  *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See
  17  *   the GNU Lesser General Public License for more details.
  18  *
  19  *   You should have received a copy of the GNU Lesser General Public License
  20  *   along with this library; if not, write to the Free Software
  21  *   Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
  22  */
  23
  24 /* Note that BB means BUGBUG (ie something to fix eventually) */
  25
  26 #include <linux/module.h>
  27 #include <linux/fs.h>
  28 #include <linux/mount.h>
  29 #include <linux/slab.h>
  30 #include <linux/init.h>
  31 #include <linux/list.h>
  32 #include <linux/seq_file.h>
  33 #include <linux/vfs.h>
  34 #include <linux/mempool.h>
  35 #include <linux/delay.h>
  36 #include <linux/kthread.h>
  37 #include <linux/freezer.h>
  38 #include "cifsfs.h"
  39 #include "cifspdu.h"
  40 #define DECLARE_GLOBALS_HERE
  41 #include "cifsglob.h"
  42 #include "cifsproto.h"
  43 #include "cifs_debug.h"
  44 #include "cifs_fs_sb.h"
  45 #include <linux/mm.h>
  46 #define CIFS_MAGIC_NUMBER 0xFF534D42    /* the first four bytes of SMB PDUs */
  47
  48 #ifdef CONFIG_CIFS_QUOTA
  49 static struct quotactl_ops cifs_quotactl_ops;
  50 #endif /* QUOTA */
  51
  52 #ifdef CONFIG_CIFS_EXPERIMENTAL
  53 extern struct export_operations cifs_export_ops;
  54 #endif /* EXPERIMENTAL */
  55
  56 int cifsFYI = 0;
  57 int cifsERROR = 1;
  58 int traceSMB = 0;
  59 unsigned int oplockEnabled = 1;
  60 unsigned int experimEnabled = 0;
  61 unsigned int linuxExtEnabled = 1;
  62 unsigned int lookupCacheEnabled = 1;
  63 unsigned int multiuser_mount = 0;
  64 unsigned int extended_security = CIFSSEC_DEF;
  65 /* unsigned int ntlmv2_support = 0; */
  66 unsigned int sign_CIFS_PDUs = 1;
  67 extern struct task_struct * oplockThread; /* remove sparse warning */
  68 struct task_struct * oplockThread = NULL;
  69 /* extern struct task_struct * dnotifyThread; remove sparse warning */
  70 static struct task_struct * dnotifyThread = NULL;
  71 static const struct super_operations cifs_super_ops;
  72 unsigned int CIFSMaxBufSize = CIFS_MAX_MSGSIZE;
  73 module_param(CIFSMaxBufSize, int, 0);
  74 MODULE_PARM_DESC(CIFSMaxBufSize,"Network buffer size (not including header). Default: 16384 Range: 8192 to 130048");
  75 unsigned int cifs_min_rcv = CIFS_MIN_RCV_POOL;
  76 module_param(cifs_min_rcv, int, 0);
  77 MODULE_PARM_DESC(cifs_min_rcv,"Network buffers in pool. Default: 4 Range: 1 to 64");
  78 unsigned int cifs_min_small = 30;
  79 module_param(cifs_min_small, int, 0);
  80 MODULE_PARM_DESC(cifs_min_small,"Small network buffers in pool. Default: 30 Range: 2 to 256");
  81 unsigned int cifs_max_pending = CIFS_MAX_REQ;
  82 module_param(cifs_max_pending, int, 0);
  83 MODULE_PARM_DESC(cifs_max_pending,"Simultaneous requests to server. Default: 50 Range: 2 to 256");
  84
  85 extern mempool_t *cifs_sm_req_poolp;
  86 extern mempool_t *cifs_req_poolp;
  87 extern mempool_t *cifs_mid_poolp;
  88
  89 extern struct kmem_cache *cifs_oplock_cachep;
  90
  91 static int
  92 cifs_read_super(struct super_block *sb, void *data,
  93                 const char *devname, int silent)
  94 {
  95         struct inode *inode;
  96         struct cifs_sb_info *cifs_sb;
  97         int rc = 0;
  98
  99         /* BB should we make this contingent on mount parm? */
 100         sb->s_flags |= MS_NODIRATIME | MS_NOATIME;
 101         sb->s_fs_info = kzalloc(sizeof(struct cifs_sb_info),GFP_KERNEL);
 102         cifs_sb = CIFS_SB(sb);
 103         if(cifs_sb == NULL)
 104                 return -ENOMEM;
 105
 106         rc = cifs_mount(sb, cifs_sb, data, devname);
 107
 108         if (rc) {
 109                 if (!silent)
 110                         cERROR(1,
 111                                ("cifs_mount failed w/return code = %d", rc));
 112                 goto out_mount_failed;
 113         }
 114
 115         sb->s_magic = CIFS_MAGIC_NUMBER;
 116         sb->s_op = &cifs_super_ops;
 117 #ifdef CONFIG_CIFS_EXPERIMENTAL
 118         if(experimEnabled != 0)
 119                 sb->s_export_op = &cifs_export_ops;
 120 #endif /* EXPERIMENTAL */
 121 /*      if(cifs_sb->tcon->ses->server->maxBuf > MAX_CIFS_HDR_SIZE + 512)
 122             sb->s_blocksize = cifs_sb->tcon->ses->server->maxBuf - MAX_CIFS_HDR_SIZE; */
 123 #ifdef CONFIG_CIFS_QUOTA
 124         sb->s_qcop = &cifs_quotactl_ops;
 125 #endif
 126         sb->s_blocksize = CIFS_MAX_MSGSIZE;
 127         sb->s_blocksize_bits = 14;      /* default 2**14 = CIFS_MAX_MSGSIZE */
 128         inode = iget(sb, ROOT_I);
 129
 130         if (!inode) {
 131                 rc = -ENOMEM;
 132                 goto out_no_root;
 133         }
 134
 135         sb->s_root = d_alloc_root(inode);
 136
 137         if (!sb->s_root) {
 138                 rc = -ENOMEM;
 139                 goto out_no_root;
 140         }
 141
 142         return 0;
 143
 144 out_no_root:
 145         cERROR(1, ("cifs_read_super: get root inode failed"));
 146         if (inode)
 147                 iput(inode);
 148
 149 out_mount_failed:
 150         if(cifs_sb) {
 151                 if(cifs_sb->local_nls)
 152                         unload_nls(cifs_sb->local_nls);
 153                 kfree(cifs_sb);
 154         }
 155         return rc;
 156 }
 157
 158 static void
 159 cifs_put_super(struct super_block *sb)
 160 {
 161         int rc = 0;
 162         struct cifs_sb_info *cifs_sb;
 163
 164         cFYI(1, ("In cifs_put_super"));
 165         cifs_sb = CIFS_SB(sb);
 166         if(cifs_sb == NULL) {
 167                 cFYI(1,("Empty cifs superblock info passed to unmount"));
 168                 return;
 169         }
 170         rc = cifs_umount(sb, cifs_sb);
 171         if (rc) {
 172                 cERROR(1, ("cifs_umount failed with return code %d", rc));
 173         }
 174         unload_nls(cifs_sb->local_nls);
 175         kfree(cifs_sb);
 176         return;
 177 }
 178
 179 static int
 180 cifs_statfs(struct dentry *dentry, struct kstatfs *buf)
 181 {
 182         struct super_block *sb = dentry->d_sb;
 183         int xid;
 184         int rc = -EOPNOTSUPP;
 185         struct cifs_sb_info *cifs_sb;
 186         struct cifsTconInfo *pTcon;
 187
 188         xid = GetXid();
 189
 190         cifs_sb = CIFS_SB(sb);
 191         pTcon = cifs_sb->tcon;
 192
 193         buf->f_type = CIFS_MAGIC_NUMBER;
 194
 195         /* instead could get the real value via SMB_QUERY_FS_ATTRIBUTE_INFO */
 196         buf->f_namelen = PATH_MAX; /* PATH_MAX may be too long - it would
 197                                       presumably be total path, but note
 198                                       that some servers (includinng Samba 3)
 199                                       have a shorter maximum path */
 200         buf->f_files = 0;       /* undefined */
 201         buf->f_ffree = 0;       /* unlimited */
 202
 203 /* BB we could add a second check for a QFS Unix capability bit */
 204 /* BB FIXME check CIFS_POSIX_EXTENSIONS Unix cap first FIXME BB */
 205     if ((pTcon->ses->capabilities & CAP_UNIX) && (CIFS_POSIX_EXTENSIONS &
 206                         le64_to_cpu(pTcon->fsUnixInfo.Capability)))
 207             rc = CIFSSMBQFSPosixInfo(xid, pTcon, buf);
 208
 209     /* Only need to call the old QFSInfo if failed
 210     on newer one */
 211     if(rc)
 212         if(pTcon->ses->capabilities & CAP_NT_SMBS)
 213                 rc = CIFSSMBQFSInfo(xid, pTcon, buf); /* not supported by OS2 */
 214
 215         /* Some old Windows servers also do not support level 103, retry with
 216            older level one if old server failed the previous call or we
 217            bypassed it because we detected that this was an older LANMAN sess */
 218         if(rc)
 219                 rc = SMBOldQFSInfo(xid, pTcon, buf);
 220         /*
 221            int f_type;
 222            __fsid_t f_fsid;
 223            int f_namelen;  */
 224         /* BB get from info in tcon struct at mount time call to QFSAttrInfo */
 225         FreeXid(xid);
 226         return 0;               /* always return success? what if volume is no
 227                                    longer available? */
 228 }
 229
 230 static int cifs_permission(struct inode * inode, int mask, struct nameidata *nd)
 231 {
 232         struct cifs_sb_info *cifs_sb;
 233
 234         cifs_sb = CIFS_SB(inode->i_sb);
 235
 236         if (cifs_sb->mnt_cifs_flags & CIFS_MOUNT_NO_PERM) {
 237                 return 0;
 238         } else /* file mode might have been restricted at mount time
 239                 on the client (above and beyond ACL on servers) for
 240                 servers which do not support setting and viewing mode bits,
 241                 so allowing client to check permissions is useful */
 242                 return generic_permission(inode, mask, NULL);
 243 }
 244
 245 static struct kmem_cache *cifs_inode_cachep;
 246 static struct kmem_cache *cifs_req_cachep;
 247 static struct kmem_cache *cifs_mid_cachep;
 248 struct kmem_cache *cifs_oplock_cachep;
 249 static struct kmem_cache *cifs_sm_req_cachep;
 250 mempool_t *cifs_sm_req_poolp;
 251 mempool_t *cifs_req_poolp;
 252 mempool_t *cifs_mid_poolp;
 253
 254 static struct inode *
 255 cifs_alloc_inode(struct super_block *sb)
 256 {
 257         struct cifsInodeInfo *cifs_inode;
 258         cifs_inode = kmem_cache_alloc(cifs_inode_cachep, GFP_KERNEL);
 259         if (!cifs_inode)
 260                 return NULL;
 261         cifs_inode->cifsAttrs = 0x20;   /* default */
 262         atomic_set(&cifs_inode->inUse, 0);
 263         cifs_inode->time = 0;
 264         /* Until the file is open and we have gotten oplock
 265         info back from the server, can not assume caching of
 266         file data or metadata */
 267         cifs_inode->clientCanCacheRead = FALSE;
 268         cifs_inode->clientCanCacheAll = FALSE;
 269         cifs_inode->vfs_inode.i_blkbits = 14;  /* 2**14 = CIFS_MAX_MSGSIZE */
 270
 271         /* Can not set i_flags here - they get immediately overwritten
 272            to zero by the VFS */
 273 /*      cifs_inode->vfs_inode.i_flags = S_NOATIME | S_NOCMTIME;*/
 274         INIT_LIST_HEAD(&cifs_inode->openFileList);
 275         return &cifs_inode->vfs_inode;
 276 }
 277
 278 static void
 279 cifs_destroy_inode(struct inode *inode)
 280 {
 281         kmem_cache_free(cifs_inode_cachep, CIFS_I(inode));
 282 }
 283
 284 /*
 285  * cifs_show_options() is for displaying mount options in /proc/mounts.
 286  * Not all settable options are displayed but most of the important
 287  * ones are.
 288  */
 289 static int
 290 cifs_show_options(struct seq_file *s, struct vfsmount *m)
 291 {
 292         struct cifs_sb_info *cifs_sb;
 293
 294         cifs_sb = CIFS_SB(m->mnt_sb);
 295
 296         if (cifs_sb) {
 297                 if (cifs_sb->tcon) {
 298 /* BB add prepath to mount options displayed */
 299                         seq_printf(s, ",unc=%s", cifs_sb->tcon->treeName);
 300                         if (cifs_sb->tcon->ses) {
 301                                 if (cifs_sb->tcon->ses->userName)
 302                                         seq_printf(s, ",username=%s",
 303                                            cifs_sb->tcon->ses->userName);
 304                                 if(cifs_sb->tcon->ses->domainName)
 305                                         seq_printf(s, ",domain=%s",
 306                                            cifs_sb->tcon->ses->domainName);
 307                         }
 308                 }
 309                 seq_printf(s, ",rsize=%d",cifs_sb->rsize);
 310                 seq_printf(s, ",wsize=%d",cifs_sb->wsize);
 311         }
 312         return 0;
 313 }
 314
 315 #ifdef CONFIG_CIFS_QUOTA
 316 int cifs_xquota_set(struct super_block * sb, int quota_type, qid_t qid,
 317                 struct fs_disk_quota * pdquota)
 318 {
 319         int xid;
 320         int rc = 0;
 321         struct cifs_sb_info *cifs_sb = CIFS_SB(sb);
 322         struct cifsTconInfo *pTcon;
 323
 324         if(cifs_sb)
 325                 pTcon = cifs_sb->tcon;
 326         else
 327                 return -EIO;
 328
 329
 330         xid = GetXid();
 331         if(pTcon) {
 332                 cFYI(1,("set type: 0x%x id: %d",quota_type,qid));
 333         } else {
 334                 return -EIO;
 335         }
 336
 337         FreeXid(xid);
 338         return rc;
 339 }
 340
 341 int cifs_xquota_get(struct super_block * sb, int quota_type, qid_t qid,
 342                 struct fs_disk_quota * pdquota)
 343 {
 344         int xid;
 345         int rc = 0;
 346         struct cifs_sb_info *cifs_sb = CIFS_SB(sb);
 347         struct cifsTconInfo *pTcon;
 348
 349         if(cifs_sb)
 350                 pTcon = cifs_sb->tcon;
 351         else
 352                 return -EIO;
 353
 354         xid = GetXid();
 355         if(pTcon) {
 356                 cFYI(1,("set type: 0x%x id: %d",quota_type,qid));
 357         } else {
 358                 rc = -EIO;
 359         }
 360
 361         FreeXid(xid);
 362         return rc;
 363 }
 364
 365 int cifs_xstate_set(struct super_block * sb, unsigned int flags, int operation)
 366 {
 367         int xid;
 368         int rc = 0;
 369         struct cifs_sb_info *cifs_sb = CIFS_SB(sb);
 370         struct cifsTconInfo *pTcon;
 371
 372         if(cifs_sb)
 373                 pTcon = cifs_sb->tcon;
 374         else
 375                 return -EIO;
 376
 377         xid = GetXid();
 378         if(pTcon) {
 379                 cFYI(1,("flags: 0x%x operation: 0x%x",flags,operation));
 380         } else {
 381                 rc = -EIO;
 382         }
 383
 384         FreeXid(xid);
 385         return rc;
 386 }
 387
 388 int cifs_xstate_get(struct super_block * sb, struct fs_quota_stat *qstats)
 389 {
 390         int xid;
 391         int rc = 0;
 392         struct cifs_sb_info *cifs_sb = CIFS_SB(sb);
 393         struct cifsTconInfo *pTcon;
 394
 395         if(cifs_sb) {
 396                 pTcon = cifs_sb->tcon;
 397         } else {
 398                 return -EIO;
 399         }
 400         xid = GetXid();
 401         if(pTcon) {
 402                 cFYI(1,("pqstats %p",qstats));
 403         } else {
 404                 rc = -EIO;
 405         }
 406
 407         FreeXid(xid);
 408         return rc;
 409 }
 410
 411 static struct quotactl_ops cifs_quotactl_ops = {
 412         .set_xquota     = cifs_xquota_set,
 413         .get_xquota     = cifs_xquota_set,
 414         .set_xstate     = cifs_xstate_set,
 415         .get_xstate     = cifs_xstate_get,
 416 };
 417 #endif
 418
 419 static void cifs_umount_begin(struct vfsmount * vfsmnt, int flags)
 420 {
 421         struct cifs_sb_info *cifs_sb;
 422         struct cifsTconInfo * tcon;
 423
 424         if (!(flags & MNT_FORCE))
 425                 return;
 426         cifs_sb = CIFS_SB(vfsmnt->mnt_sb);
 427         if(cifs_sb == NULL)
 428                 return;
 429
 430         tcon = cifs_sb->tcon;
 431         if(tcon == NULL)
 432                 return;
 433         down(&tcon->tconSem);
 434         if (atomic_read(&tcon->useCount) == 1)
 435                 tcon->tidStatus = CifsExiting;
 436         up(&tcon->tconSem);
 437
 438         /* cancel_brl_requests(tcon); */ /* BB mark all brl mids as exiting */
 439         /* cancel_notify_requests(tcon); */
 440         if(tcon->ses && tcon->ses->server)
 441         {
 442                 cFYI(1,("wake up tasks now - umount begin not complete"));
 443                 wake_up_all(&tcon->ses->server->request_q);
 444                 wake_up_all(&tcon->ses->server->response_q);
 445                 msleep(1); /* yield */
 446                 /* we have to kick the requests once more */
 447                 wake_up_all(&tcon->ses->server->response_q);
 448                 msleep(1);
 449         }
 450 /* BB FIXME - finish add checks for tidStatus BB */
 451
 452         return;
 453 }
 454
 455 #ifdef CONFIG_CIFS_STATS2
 456 static int cifs_show_stats(struct seq_file *s, struct vfsmount *mnt)
 457 {
 458         /* BB FIXME */
 459         return 0;
 460 }
 461 #endif
 462
 463 static int cifs_remount(struct super_block *sb, int *flags, char *data)
 464 {
 465         *flags |= MS_NODIRATIME;
 466         return 0;
 467 }
 468
 469 static const struct super_operations cifs_super_ops = {
 470         .read_inode = cifs_read_inode,
 471         .put_super = cifs_put_super,
 472         .statfs = cifs_statfs,
 473         .alloc_inode = cifs_alloc_inode,
 474         .destroy_inode = cifs_destroy_inode,
 475 /*      .drop_inode         = generic_delete_inode,
 476         .delete_inode   = cifs_delete_inode,  *//* Do not need the above two functions
 477    unless later we add lazy close of inodes or unless the kernel forgets to call
 478    us with the same number of releases (closes) as opens */
 479         .show_options = cifs_show_options,
 480         .umount_begin   = cifs_umount_begin,
 481         .remount_fs = cifs_remount,
 482 #ifdef CONFIG_CIFS_STATS2
 483         .show_stats = cifs_show_stats,
 484 #endif
 485 };
 486
 487 static int
 488 cifs_get_sb(struct file_system_type *fs_type,
 489             int flags, const char *dev_name, void *data, struct vfsmount *mnt)
 490 {
 491         int rc;
 492         struct super_block *sb = sget(fs_type, NULL, set_anon_super, NULL);
 493
 494         cFYI(1, ("Devname: %s flags: %d ", dev_name, flags));
 495
 496         if (IS_ERR(sb))
 497                 return PTR_ERR(sb);
 498
 499         sb->s_flags = flags;
 500
 501         rc = cifs_read_super(sb, data, dev_name, flags & MS_SILENT ? 1 : 0);
 502         if (rc) {
 503                 up_write(&sb->s_umount);
 504                 deactivate_super(sb);
 505                 return rc;
 506         }
 507         sb->s_flags |= MS_ACTIVE;
 508         return simple_set_mnt(mnt, sb);
 509 }
 510
 511 static ssize_t cifs_file_aio_write(struct kiocb *iocb, const struct iovec *iov,
 512                                    unsigned long nr_segs, loff_t pos)
 513 {
 514         struct inode *inode = iocb->ki_filp->f_path.dentry->d_inode;
 515         ssize_t written;
 516
 517         written = generic_file_aio_write(iocb, iov, nr_segs, pos);
 518         if (!CIFS_I(inode)->clientCanCacheAll)
 519                 filemap_fdatawrite(inode->i_mapping);
 520         return written;
 521 }
 522
 523 static loff_t cifs_llseek(struct file *file, loff_t offset, int origin)
 524 {
 525         /* origin == SEEK_END => we must revalidate the cached file length */
 526         if (origin == SEEK_END) {
 527                 int retval;
 528
 529                 /* some applications poll for the file length in this strange
 530                    way so we must seek to end on non-oplocked files by
 531                    setting the revalidate time to zero */
 532                 if(file->f_path.dentry->d_inode)
 533                         CIFS_I(file->f_path.dentry->d_inode)->time = 0;
 534
 535                 retval = cifs_revalidate(file->f_path.dentry);
 536                 if (retval < 0)
 537                         return (loff_t)retval;
 538         }
 539         return remote_llseek(file, offset, origin);
 540 }
 541
 542 static struct file_system_type cifs_fs_type = {
 543         .owner = THIS_MODULE,
 544         .name = "cifs",
 545         .get_sb = cifs_get_sb,
 546         .kill_sb = kill_anon_super,
 547         /*  .fs_flags */
 548 };
 549 const struct inode_operations cifs_dir_inode_ops = {
 550         .create = cifs_create,
 551         .lookup = cifs_lookup,
 552         .getattr = cifs_getattr,
 553         .unlink = cifs_unlink,
 554         .link = cifs_hardlink,
 555         .mkdir = cifs_mkdir,
 556         .rmdir = cifs_rmdir,
 557         .rename = cifs_rename,
 558         .permission = cifs_permission,
 559 /*      revalidate:cifs_revalidate,   */
 560         .setattr = cifs_setattr,
 561         .symlink = cifs_symlink,
 562         .mknod   = cifs_mknod,
 563 #ifdef CONFIG_CIFS_XATTR
 564         .setxattr = cifs_setxattr,
 565         .getxattr = cifs_getxattr,
 566         .listxattr = cifs_listxattr,
 567         .removexattr = cifs_removexattr,
 568 #endif
 569 };
 570
 571 const struct inode_operations cifs_file_inode_ops = {
 572 /*      revalidate:cifs_revalidate, */
 573         .setattr = cifs_setattr,
 574         .getattr = cifs_getattr, /* do we need this anymore? */
 575         .rename = cifs_rename,
 576         .permission = cifs_permission,
 577 #ifdef CONFIG_CIFS_XATTR
 578         .setxattr = cifs_setxattr,
 579         .getxattr = cifs_getxattr,
 580         .listxattr = cifs_listxattr,
 581         .removexattr = cifs_removexattr,
 582 #endif
 583 };
 584
 585 const struct inode_operations cifs_symlink_inode_ops = {
 586         .readlink = generic_readlink,
 587         .follow_link = cifs_follow_link,
 588         .put_link = cifs_put_link,
 589         .permission = cifs_permission,
 590         /* BB add the following two eventually */
 591         /* revalidate: cifs_revalidate,
 592            setattr:    cifs_notify_change, *//* BB do we need notify change */
 593 #ifdef CONFIG_CIFS_XATTR
 594         .setxattr = cifs_setxattr,
 595         .getxattr = cifs_getxattr,
 596         .listxattr = cifs_listxattr,
 597         .removexattr = cifs_removexattr,
 598 #endif
 599 };
 600
 601 const struct file_operations cifs_file_ops = {
 602         .read = do_sync_read,
 603         .write = do_sync_write,
 604         .aio_read = generic_file_aio_read,
 605         .aio_write = cifs_file_aio_write,
 606         .open = cifs_open,
 607         .release = cifs_close,
 608         .lock = cifs_lock,
 609         .fsync = cifs_fsync,
 610         .flush = cifs_flush,
 611         .mmap  = cifs_file_mmap,
 612         .sendfile = generic_file_sendfile,
 613         .llseek = cifs_llseek,
 614 #ifdef CONFIG_CIFS_POSIX
 615         .ioctl  = cifs_ioctl,
 616 #endif /* CONFIG_CIFS_POSIX */
 617
 618 #ifdef CONFIG_CIFS_EXPERIMENTAL
 619         .dir_notify = cifs_dir_notify,
 620 #endif /* CONFIG_CIFS_EXPERIMENTAL */
 621 };
 622
 623 const struct file_operations cifs_file_direct_ops = {
 624         /* no mmap, no aio, no readv -
 625            BB reevaluate whether they can be done with directio, no cache */
 626         .read = cifs_user_read,
 627         .write = cifs_user_write,
 628         .open = cifs_open,
 629         .release = cifs_close,
 630         .lock = cifs_lock,
 631         .fsync = cifs_fsync,
 632         .flush = cifs_flush,
 633         .sendfile = generic_file_sendfile, /* BB removeme BB */
 634 #ifdef CONFIG_CIFS_POSIX
 635         .ioctl  = cifs_ioctl,
 636 #endif /* CONFIG_CIFS_POSIX */
 637         .llseek = cifs_llseek,
 638 #ifdef CONFIG_CIFS_EXPERIMENTAL
 639         .dir_notify = cifs_dir_notify,
 640 #endif /* CONFIG_CIFS_EXPERIMENTAL */
 641 };
 642 const struct file_operations cifs_file_nobrl_ops = {
 643         .read = do_sync_read,
 644         .write = do_sync_write,
 645         .aio_read = generic_file_aio_read,
 646         .aio_write = cifs_file_aio_write,
 647         .open = cifs_open,
 648         .release = cifs_close,
 649         .fsync = cifs_fsync,
 650         .flush = cifs_flush,
 651         .mmap  = cifs_file_mmap,
 652         .sendfile = generic_file_sendfile,
 653         .llseek = cifs_llseek,
 654 #ifdef CONFIG_CIFS_POSIX
 655         .ioctl  = cifs_ioctl,
 656 #endif /* CONFIG_CIFS_POSIX */
 657
 658 #ifdef CONFIG_CIFS_EXPERIMENTAL
 659         .dir_notify = cifs_dir_notify,
 660 #endif /* CONFIG_CIFS_EXPERIMENTAL */
 661 };
 662
 663 const struct file_operations cifs_file_direct_nobrl_ops = {
 664         /* no mmap, no aio, no readv -
 665            BB reevaluate whether they can be done with directio, no cache */
 666         .read = cifs_user_read,
 667         .write = cifs_user_write,
 668         .open = cifs_open,
 669         .release = cifs_close,
 670         .fsync = cifs_fsync,
 671         .flush = cifs_flush,
 672         .sendfile = generic_file_sendfile, /* BB removeme BB */
 673 #ifdef CONFIG_CIFS_POSIX
 674         .ioctl  = cifs_ioctl,
 675 #endif /* CONFIG_CIFS_POSIX */
 676         .llseek = cifs_llseek,
 677 #ifdef CONFIG_CIFS_EXPERIMENTAL
 678         .dir_notify = cifs_dir_notify,
 679 #endif /* CONFIG_CIFS_EXPERIMENTAL */
 680 };
 681
 682 const struct file_operations cifs_dir_ops = {
 683         .readdir = cifs_readdir,
 684         .release = cifs_closedir,
 685         .read    = generic_read_dir,
 686 #ifdef CONFIG_CIFS_EXPERIMENTAL
 687         .dir_notify = cifs_dir_notify,
 688 #endif /* CONFIG_CIFS_EXPERIMENTAL */
 689         .ioctl  = cifs_ioctl,
 690 };
 691
 692 static void
 693 cifs_init_once(void *inode, struct kmem_cache * cachep, unsigned long flags)
 694 {
 695         struct cifsInodeInfo *cifsi = inode;
 696
 697         if ((flags & (SLAB_CTOR_VERIFY | SLAB_CTOR_CONSTRUCTOR)) ==
 698             SLAB_CTOR_CONSTRUCTOR) {
 699                 inode_init_once(&cifsi->vfs_inode);
 700                 INIT_LIST_HEAD(&cifsi->lockList);
 701         }
 702 }
 703
 704 static int
 705 cifs_init_inodecache(void)
 706 {
 707         cifs_inode_cachep = kmem_cache_create("cifs_inode_cache",
 708                                               sizeof (struct cifsInodeInfo),
 709                                               0, (SLAB_RECLAIM_ACCOUNT|
 710                                                 SLAB_MEM_SPREAD),
 711                                               cifs_init_once, NULL);
 712         if (cifs_inode_cachep == NULL)
 713                 return -ENOMEM;
 714
 715         return 0;
 716 }
 717
 718 static void
 719 cifs_destroy_inodecache(void)
 720 {
 721         kmem_cache_destroy(cifs_inode_cachep);
 722 }
 723
 724 static int
 725 cifs_init_request_bufs(void)
 726 {
 727         if(CIFSMaxBufSize < 8192) {
 728         /* Buffer size can not be smaller than 2 * PATH_MAX since maximum
 729         Unicode path name has to fit in any SMB/CIFS path based frames */
 730                 CIFSMaxBufSize = 8192;
 731         } else if (CIFSMaxBufSize > 1024*127) {
 732                 CIFSMaxBufSize = 1024 * 127;
 733         } else {
 734                 CIFSMaxBufSize &= 0x1FE00; /* Round size to even 512 byte mult*/
 735         }
 736 /*      cERROR(1,("CIFSMaxBufSize %d 0x%x",CIFSMaxBufSize,CIFSMaxBufSize)); */
 737         cifs_req_cachep = kmem_cache_create("cifs_request",
 738                                             CIFSMaxBufSize +
 739                                             MAX_CIFS_HDR_SIZE, 0,
 740                                             SLAB_HWCACHE_ALIGN, NULL, NULL);
 741         if (cifs_req_cachep == NULL)
 742                 return -ENOMEM;
 743
 744         if(cifs_min_rcv < 1)
 745                 cifs_min_rcv = 1;
 746         else if (cifs_min_rcv > 64) {
 747                 cifs_min_rcv = 64;
 748                 cERROR(1,("cifs_min_rcv set to maximum (64)"));
 749         }
 750
 751         cifs_req_poolp = mempool_create_slab_pool(cifs_min_rcv,
 752                                                   cifs_req_cachep);
 753
 754         if(cifs_req_poolp == NULL) {
 755                 kmem_cache_destroy(cifs_req_cachep);
 756                 return -ENOMEM;
 757         }
 758         /* MAX_CIFS_SMALL_BUFFER_SIZE bytes is enough for most SMB responses and
 759         almost all handle based requests (but not write response, nor is it
 760         sufficient for path based requests).  A smaller size would have
 761         been more efficient (compacting multiple slab items on one 4k page)
 762         for the case in which debug was on, but this larger size allows
 763         more SMBs to use small buffer alloc and is still much more
 764         efficient to alloc 1 per page off the slab compared to 17K (5page)
 765         alloc of large cifs buffers even when page debugging is on */
 766         cifs_sm_req_cachep = kmem_cache_create("cifs_small_rq",
 767                         MAX_CIFS_SMALL_BUFFER_SIZE, 0, SLAB_HWCACHE_ALIGN,
 768                         NULL, NULL);
 769         if (cifs_sm_req_cachep == NULL) {
 770                 mempool_destroy(cifs_req_poolp);
 771                 kmem_cache_destroy(cifs_req_cachep);
 772                 return -ENOMEM;
 773         }
 774
 775         if(cifs_min_small < 2)
 776                 cifs_min_small = 2;
 777         else if (cifs_min_small > 256) {
 778                 cifs_min_small = 256;
 779                 cFYI(1,("cifs_min_small set to maximum (256)"));
 780         }
 781
 782         cifs_sm_req_poolp = mempool_create_slab_pool(cifs_min_small,
 783                                                      cifs_sm_req_cachep);
 784
 785         if(cifs_sm_req_poolp == NULL) {
 786                 mempool_destroy(cifs_req_poolp);
 787                 kmem_cache_destroy(cifs_req_cachep);
 788                 kmem_cache_destroy(cifs_sm_req_cachep);
 789                 return -ENOMEM;
 790         }
 791
 792         return 0;
 793 }
 794
 795 static void
 796 cifs_destroy_request_bufs(void)
 797 {
 798         mempool_destroy(cifs_req_poolp);
 799         kmem_cache_destroy(cifs_req_cachep);
 800         mempool_destroy(cifs_sm_req_poolp);
 801         kmem_cache_destroy(cifs_sm_req_cachep);
 802 }
 803
 804 static int
 805 cifs_init_mids(void)
 806 {
 807         cifs_mid_cachep = kmem_cache_create("cifs_mpx_ids",
 808                                 sizeof (struct mid_q_entry), 0,
 809                                 SLAB_HWCACHE_ALIGN, NULL, NULL);
 810         if (cifs_mid_cachep == NULL)
 811                 return -ENOMEM;
 812
 813         /* 3 is a reasonable minimum number of simultaneous operations */
 814         cifs_mid_poolp = mempool_create_slab_pool(3, cifs_mid_cachep);
 815         if(cifs_mid_poolp == NULL) {
 816                 kmem_cache_destroy(cifs_mid_cachep);
 817                 return -ENOMEM;
 818         }
 819
 820         cifs_oplock_cachep = kmem_cache_create("cifs_oplock_structs",
 821                                 sizeof (struct oplock_q_entry), 0,
 822                                 SLAB_HWCACHE_ALIGN, NULL, NULL);
 823         if (cifs_oplock_cachep == NULL) {
 824                 kmem_cache_destroy(cifs_mid_cachep);
 825                 mempool_destroy(cifs_mid_poolp);
 826                 return -ENOMEM;
 827         }
 828
 829         return 0;
 830 }
 831
 832 static void
 833 cifs_destroy_mids(void)
 834 {
 835         mempool_destroy(cifs_mid_poolp);
 836         kmem_cache_destroy(cifs_mid_cachep);
 837         kmem_cache_destroy(cifs_oplock_cachep);
 838 }
 839
 840 static int cifs_oplock_thread(void * dummyarg)
 841 {
 842         struct oplock_q_entry * oplock_item;
 843         struct cifsTconInfo *pTcon;
 844         struct inode * inode;
 845         __u16  netfid;
 846         int rc;
 847
 848         do {
 849                 if (try_to_freeze())
 850                         continue;
 851
 852                 spin_lock(&GlobalMid_Lock);
 853                 if(list_empty(&GlobalOplock_Q)) {
 854                         spin_unlock(&GlobalMid_Lock);
 855                         set_current_state(TASK_INTERRUPTIBLE);
 856                         schedule_timeout(39*HZ);
 857                 } else {
 858                         oplock_item = list_entry(GlobalOplock_Q.next,
 859                                 struct oplock_q_entry, qhead);
 860                         if(oplock_item) {
 861                                 cFYI(1,("found oplock item to write out"));
 862                                 pTcon = oplock_item->tcon;
 863                                 inode = oplock_item->pinode;
 864                                 netfid = oplock_item->netfid;
 865                                 spin_unlock(&GlobalMid_Lock);
 866                                 DeleteOplockQEntry(oplock_item);
 867                                 /* can not grab inode sem here since it would
 868                                 deadlock when oplock received on delete
 869                                 since vfs_unlink holds the i_mutex across
 870                                 the call */
 871                                 /* mutex_lock(&inode->i_mutex);*/
 872                                 if (S_ISREG(inode->i_mode)) {
 873                                         rc = filemap_fdatawrite(inode->i_mapping);
 874                                         if(CIFS_I(inode)->clientCanCacheRead == 0) {
 875                                                 filemap_fdatawait(inode->i_mapping);
 876                                                 invalidate_remote_inode(inode);
 877                                         }
 878                                 } else
 879                                         rc = 0;
 880                                 /* mutex_unlock(&inode->i_mutex);*/
 881                                 if (rc)
 882                                         CIFS_I(inode)->write_behind_rc = rc;
 883                                 cFYI(1,("Oplock flush inode %p rc %d",inode,rc));
 884
 885                                 /* releasing a stale oplock after recent reconnection
 886                                 of smb session using a now incorrect file
 887                                 handle is not a data integrity issue but do
 888                                 not bother sending an oplock release if session
 889                                 to server still is disconnected since oplock
 890                                 already released by the server in that case */
 891                                 if(pTcon->tidStatus != CifsNeedReconnect) {
 892                                     rc = CIFSSMBLock(0, pTcon, netfid,
 893                                             0 /* len */ , 0 /* offset */, 0,
 894                                             0, LOCKING_ANDX_OPLOCK_RELEASE,
 895                                             0 /* wait flag */);
 896                                         cFYI(1,("Oplock release rc = %d ",rc));
 897                                 }
 898                         } else
 899                                 spin_unlock(&GlobalMid_Lock);
 900                         set_current_state(TASK_INTERRUPTIBLE);
 901                         schedule_timeout(1);  /* yield in case q were corrupt */
 902                 }
 903         } while (!kthread_should_stop());
 904
 905         return 0;
 906 }
 907
 908 static int cifs_dnotify_thread(void * dummyarg)
 909 {
 910         struct list_head *tmp;
 911         struct cifsSesInfo *ses;
 912
 913         do {
 914                 if (try_to_freeze())
 915                         continue;
 916                 set_current_state(TASK_INTERRUPTIBLE);
 917                 schedule_timeout(15*HZ);
 918                 read_lock(&GlobalSMBSeslock);
 919                 /* check if any stuck requests that need
 920                    to be woken up and wakeq so the
 921                    thread can wake up and error out */
 922                 list_for_each(tmp, &GlobalSMBSessionList) {
 923                         ses = list_entry(tmp, struct cifsSesInfo,
 924                                 cifsSessionList);
 925                         if(ses && ses->server &&
 926                              atomic_read(&ses->server->inFlight))
 927                                 wake_up_all(&ses->server->response_q);
 928                 }
 929                 read_unlock(&GlobalSMBSeslock);
 930         } while (!kthread_should_stop());
 931
 932         return 0;
 933 }
 934
 935 static int __init
 936 init_cifs(void)
 937 {
 938         int rc = 0;
 939 #ifdef CONFIG_PROC_FS
 940         cifs_proc_init();
 941 #endif
 942 /*      INIT_LIST_HEAD(&GlobalServerList);*/    /* BB not implemented yet */
 943         INIT_LIST_HEAD(&GlobalSMBSessionList);
 944         INIT_LIST_HEAD(&GlobalTreeConnectionList);
 945         INIT_LIST_HEAD(&GlobalOplock_Q);
 946 #ifdef CONFIG_CIFS_EXPERIMENTAL
 947         INIT_LIST_HEAD(&GlobalDnotifyReqList);
 948         INIT_LIST_HEAD(&GlobalDnotifyRsp_Q);
 949 #endif
 950 /*
 951  *  Initialize Global counters
 952  */
 953         atomic_set(&sesInfoAllocCount, 0);
 954         atomic_set(&tconInfoAllocCount, 0);
 955         atomic_set(&tcpSesAllocCount,0);
 956         atomic_set(&tcpSesReconnectCount, 0);
 957         atomic_set(&tconInfoReconnectCount, 0);
 958
 959         atomic_set(&bufAllocCount, 0);
 960         atomic_set(&smBufAllocCount, 0);
 961 #ifdef CONFIG_CIFS_STATS2
 962         atomic_set(&totBufAllocCount, 0);
 963         atomic_set(&totSmBufAllocCount, 0);
 964 #endif /* CONFIG_CIFS_STATS2 */
 965
 966         atomic_set(&midCount, 0);
 967         GlobalCurrentXid = 0;
 968         GlobalTotalActiveXid = 0;
 969         GlobalMaxActiveXid = 0;
 970         memset(Local_System_Name, 0, 15);
 971         rwlock_init(&GlobalSMBSeslock);
 972         spin_lock_init(&GlobalMid_Lock);
 973
 974         if(cifs_max_pending < 2) {
 975                 cifs_max_pending = 2;
 976                 cFYI(1,("cifs_max_pending set to min of 2"));
 977         } else if(cifs_max_pending > 256) {
 978                 cifs_max_pending = 256;
 979                 cFYI(1,("cifs_max_pending set to max of 256"));
 980         }
 981
 982         rc = cifs_init_inodecache();
 983         if (rc)
 984                 goto out_clean_proc;
 985
 986         rc = cifs_init_mids();
 987         if (rc)
 988                 goto out_destroy_inodecache;
 989
 990         rc = cifs_init_request_bufs();
 991         if (rc)
 992                 goto out_destroy_mids;
 993
 994         rc = register_filesystem(&cifs_fs_type);
 995         if (rc)
 996                 goto out_destroy_request_bufs;
 997
 998         oplockThread = kthread_run(cifs_oplock_thread, NULL, "cifsoplockd");
 999         if (IS_ERR(oplockThread)) {
1000                 rc = PTR_ERR(oplockThread);
1001                 cERROR(1,("error %d create oplock thread", rc));
1002                 goto out_unregister_filesystem;
1003         }
1004
1005         dnotifyThread = kthread_run(cifs_dnotify_thread, NULL, "cifsdnotifyd");
1006         if (IS_ERR(dnotifyThread)) {
1007                 rc = PTR_ERR(dnotifyThread);
1008                 cERROR(1,("error %d create dnotify thread", rc));
1009                 goto out_stop_oplock_thread;
1010         }
1011
1012         return 0;
1013
1014  out_stop_oplock_thread:
1015         kthread_stop(oplockThread);
1016  out_unregister_filesystem:
1017         unregister_filesystem(&cifs_fs_type);
1018  out_destroy_request_bufs:
1019         cifs_destroy_request_bufs();
1020  out_destroy_mids:
1021         cifs_destroy_mids();
1022  out_destroy_inodecache:
1023         cifs_destroy_inodecache();
1024  out_clean_proc:
1025 #ifdef CONFIG_PROC_FS
1026         cifs_proc_clean();
1027 #endif
1028         return rc;
1029 }
1030
1031 static void __exit
1032 exit_cifs(void)
1033 {
1034         cFYI(0, ("In unregister ie exit_cifs"));
1035 #ifdef CONFIG_PROC_FS
1036         cifs_proc_clean();
1037 #endif
1038         unregister_filesystem(&cifs_fs_type);
1039         cifs_destroy_inodecache();
1040         cifs_destroy_mids();
1041         cifs_destroy_request_bufs();
1042         kthread_stop(oplockThread);
1043         kthread_stop(dnotifyThread);
1044 }
1045
1046 MODULE_AUTHOR("Steve French <sfrench@us.ibm.com>");
1047 MODULE_LICENSE("GPL");          /* combination of LGPL + GPL source behaves as GPL */
1048 MODULE_DESCRIPTION
1049     ("VFS to access servers complying with the SNIA CIFS Specification e.g. Samba and Windows");
1050 MODULE_VERSION(CIFS_VERSION);
1051 module_init(init_cifs)
1052 module_exit(exit_cifs)