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