cifs: vary timeout on writes past EOF based on offset (try #5)
[linux-2.6/linux-acpi-2.6/ibm-acpi-2.6.git] / fs / cifs / cifsfs.c
blob34f5701d95557d260560d625b76db7f61ae6453c
1 /*
2 * fs/cifs/cifsfs.c
4 * Copyright (C) International Business Machines Corp., 2002,2008
5 * Author(s): Steve French (sfrench@us.ibm.com)
7 * Common Internet FileSystem (CIFS) client
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.
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.
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
24 /* Note that BB means BUGBUG (ie something to fix eventually) */
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 #include <linux/key-type.h>
47 #include "dns_resolve.h"
48 #include "cifs_spnego.h"
49 #define CIFS_MAGIC_NUMBER 0xFF534D42 /* the first four bytes of SMB PDUs */
51 #ifdef CONFIG_CIFS_QUOTA
52 static struct quotactl_ops cifs_quotactl_ops;
53 #endif /* QUOTA */
55 int cifsFYI = 0;
56 int cifsERROR = 1;
57 int traceSMB = 0;
58 unsigned int oplockEnabled = 1;
59 unsigned int experimEnabled = 0;
60 unsigned int linuxExtEnabled = 1;
61 unsigned int lookupCacheEnabled = 1;
62 unsigned int multiuser_mount = 0;
63 unsigned int extended_security = CIFSSEC_DEF;
64 /* unsigned int ntlmv2_support = 0; */
65 unsigned int sign_CIFS_PDUs = 1;
66 extern struct task_struct *oplockThread; /* remove sparse warning */
67 struct task_struct *oplockThread = NULL;
68 /* extern struct task_struct * dnotifyThread; remove sparse warning */
69 #ifdef CONFIG_CIFS_EXPERIMENTAL
70 static struct task_struct *dnotifyThread = NULL;
71 #endif
72 static const struct super_operations cifs_super_ops;
73 unsigned int CIFSMaxBufSize = CIFS_MAX_MSGSIZE;
74 module_param(CIFSMaxBufSize, int, 0);
75 MODULE_PARM_DESC(CIFSMaxBufSize, "Network buffer size (not including header). "
76 "Default: 16384 Range: 8192 to 130048");
77 unsigned int cifs_min_rcv = CIFS_MIN_RCV_POOL;
78 module_param(cifs_min_rcv, int, 0);
79 MODULE_PARM_DESC(cifs_min_rcv, "Network buffers in pool. Default: 4 Range: "
80 "1 to 64");
81 unsigned int cifs_min_small = 30;
82 module_param(cifs_min_small, int, 0);
83 MODULE_PARM_DESC(cifs_min_small, "Small network buffers in pool. Default: 30 "
84 "Range: 2 to 256");
85 unsigned int cifs_max_pending = CIFS_MAX_REQ;
86 module_param(cifs_max_pending, int, 0);
87 MODULE_PARM_DESC(cifs_max_pending, "Simultaneous requests to server. "
88 "Default: 50 Range: 2 to 256");
90 extern mempool_t *cifs_sm_req_poolp;
91 extern mempool_t *cifs_req_poolp;
92 extern mempool_t *cifs_mid_poolp;
94 extern struct kmem_cache *cifs_oplock_cachep;
96 static int
97 cifs_read_super(struct super_block *sb, void *data,
98 const char *devname, int silent)
100 struct inode *inode;
101 struct cifs_sb_info *cifs_sb;
102 int rc = 0;
104 /* BB should we make this contingent on mount parm? */
105 sb->s_flags |= MS_NODIRATIME | MS_NOATIME;
106 sb->s_fs_info = kzalloc(sizeof(struct cifs_sb_info), GFP_KERNEL);
107 cifs_sb = CIFS_SB(sb);
108 if (cifs_sb == NULL)
109 return -ENOMEM;
111 #ifdef CONFIG_CIFS_DFS_UPCALL
112 /* copy mount params to sb for use in submounts */
113 /* BB: should we move this after the mount so we
114 * do not have to do the copy on failed mounts?
115 * BB: May be it is better to do simple copy before
116 * complex operation (mount), and in case of fail
117 * just exit instead of doing mount and attempting
118 * undo it if this copy fails?*/
119 if (data) {
120 int len = strlen(data);
121 cifs_sb->mountdata = kzalloc(len + 1, GFP_KERNEL);
122 if (cifs_sb->mountdata == NULL) {
123 kfree(sb->s_fs_info);
124 sb->s_fs_info = NULL;
125 return -ENOMEM;
127 strncpy(cifs_sb->mountdata, data, len + 1);
128 cifs_sb->mountdata[len] = '\0';
130 #endif
132 rc = cifs_mount(sb, cifs_sb, data, devname);
134 if (rc) {
135 if (!silent)
136 cERROR(1,
137 ("cifs_mount failed w/return code = %d", rc));
138 goto out_mount_failed;
141 sb->s_magic = CIFS_MAGIC_NUMBER;
142 sb->s_op = &cifs_super_ops;
143 /* if (cifs_sb->tcon->ses->server->maxBuf > MAX_CIFS_HDR_SIZE + 512)
144 sb->s_blocksize =
145 cifs_sb->tcon->ses->server->maxBuf - MAX_CIFS_HDR_SIZE; */
146 #ifdef CONFIG_CIFS_QUOTA
147 sb->s_qcop = &cifs_quotactl_ops;
148 #endif
149 sb->s_blocksize = CIFS_MAX_MSGSIZE;
150 sb->s_blocksize_bits = 14; /* default 2**14 = CIFS_MAX_MSGSIZE */
151 inode = cifs_iget(sb, ROOT_I);
153 if (IS_ERR(inode)) {
154 rc = PTR_ERR(inode);
155 inode = NULL;
156 goto out_no_root;
159 sb->s_root = d_alloc_root(inode);
161 if (!sb->s_root) {
162 rc = -ENOMEM;
163 goto out_no_root;
166 #ifdef CONFIG_CIFS_EXPERIMENTAL
167 if (cifs_sb->mnt_cifs_flags & CIFS_MOUNT_SERVER_INUM) {
168 cFYI(1, ("export ops supported"));
169 sb->s_export_op = &cifs_export_ops;
171 #endif /* EXPERIMENTAL */
173 return 0;
175 out_no_root:
176 cERROR(1, ("cifs_read_super: get root inode failed"));
177 if (inode)
178 iput(inode);
180 cifs_umount(sb, cifs_sb);
182 out_mount_failed:
183 if (cifs_sb) {
184 #ifdef CONFIG_CIFS_DFS_UPCALL
185 if (cifs_sb->mountdata) {
186 kfree(cifs_sb->mountdata);
187 cifs_sb->mountdata = NULL;
189 #endif
190 if (cifs_sb->local_nls)
191 unload_nls(cifs_sb->local_nls);
192 kfree(cifs_sb);
194 return rc;
197 static void
198 cifs_put_super(struct super_block *sb)
200 int rc = 0;
201 struct cifs_sb_info *cifs_sb;
203 cFYI(1, ("In cifs_put_super"));
204 cifs_sb = CIFS_SB(sb);
205 if (cifs_sb == NULL) {
206 cFYI(1, ("Empty cifs superblock info passed to unmount"));
207 return;
209 rc = cifs_umount(sb, cifs_sb);
210 if (rc)
211 cERROR(1, ("cifs_umount failed with return code %d", rc));
212 #ifdef CONFIG_CIFS_DFS_UPCALL
213 if (cifs_sb->mountdata) {
214 kfree(cifs_sb->mountdata);
215 cifs_sb->mountdata = NULL;
217 #endif
219 unload_nls(cifs_sb->local_nls);
220 kfree(cifs_sb);
221 return;
224 static int
225 cifs_statfs(struct dentry *dentry, struct kstatfs *buf)
227 struct super_block *sb = dentry->d_sb;
228 struct cifs_sb_info *cifs_sb = CIFS_SB(sb);
229 struct cifsTconInfo *tcon = cifs_sb->tcon;
230 int rc = -EOPNOTSUPP;
231 int xid;
233 xid = GetXid();
235 buf->f_type = CIFS_MAGIC_NUMBER;
238 * PATH_MAX may be too long - it would presumably be total path,
239 * but note that some servers (includinng Samba 3) have a shorter
240 * maximum path.
242 * Instead could get the real value via SMB_QUERY_FS_ATTRIBUTE_INFO.
244 buf->f_namelen = PATH_MAX;
245 buf->f_files = 0; /* undefined */
246 buf->f_ffree = 0; /* unlimited */
249 * We could add a second check for a QFS Unix capability bit
251 if ((tcon->ses->capabilities & CAP_UNIX) &&
252 (CIFS_POSIX_EXTENSIONS & le64_to_cpu(tcon->fsUnixInfo.Capability)))
253 rc = CIFSSMBQFSPosixInfo(xid, tcon, buf);
256 * Only need to call the old QFSInfo if failed on newer one,
257 * e.g. by OS/2.
259 if (rc && (tcon->ses->capabilities & CAP_NT_SMBS))
260 rc = CIFSSMBQFSInfo(xid, tcon, buf);
263 * Some old Windows servers also do not support level 103, retry with
264 * older level one if old server failed the previous call or we
265 * bypassed it because we detected that this was an older LANMAN sess
267 if (rc)
268 rc = SMBOldQFSInfo(xid, tcon, buf);
270 FreeXid(xid);
271 return 0;
274 static int cifs_permission(struct inode *inode, int mask)
276 struct cifs_sb_info *cifs_sb;
278 cifs_sb = CIFS_SB(inode->i_sb);
280 if (cifs_sb->mnt_cifs_flags & CIFS_MOUNT_NO_PERM) {
281 if ((mask & MAY_EXEC) && !execute_ok(inode))
282 return -EACCES;
283 else
284 return 0;
285 } else /* file mode might have been restricted at mount time
286 on the client (above and beyond ACL on servers) for
287 servers which do not support setting and viewing mode bits,
288 so allowing client to check permissions is useful */
289 return generic_permission(inode, mask, NULL);
292 static struct kmem_cache *cifs_inode_cachep;
293 static struct kmem_cache *cifs_req_cachep;
294 static struct kmem_cache *cifs_mid_cachep;
295 struct kmem_cache *cifs_oplock_cachep;
296 static struct kmem_cache *cifs_sm_req_cachep;
297 mempool_t *cifs_sm_req_poolp;
298 mempool_t *cifs_req_poolp;
299 mempool_t *cifs_mid_poolp;
301 static struct inode *
302 cifs_alloc_inode(struct super_block *sb)
304 struct cifsInodeInfo *cifs_inode;
305 cifs_inode = kmem_cache_alloc(cifs_inode_cachep, GFP_KERNEL);
306 if (!cifs_inode)
307 return NULL;
308 cifs_inode->cifsAttrs = 0x20; /* default */
309 atomic_set(&cifs_inode->inUse, 0);
310 cifs_inode->time = 0;
311 cifs_inode->write_behind_rc = 0;
312 /* Until the file is open and we have gotten oplock
313 info back from the server, can not assume caching of
314 file data or metadata */
315 cifs_inode->clientCanCacheRead = false;
316 cifs_inode->clientCanCacheAll = false;
317 cifs_inode->delete_pending = false;
318 cifs_inode->vfs_inode.i_blkbits = 14; /* 2**14 = CIFS_MAX_MSGSIZE */
319 cifs_inode->server_eof = 0;
321 /* Can not set i_flags here - they get immediately overwritten
322 to zero by the VFS */
323 /* cifs_inode->vfs_inode.i_flags = S_NOATIME | S_NOCMTIME;*/
324 INIT_LIST_HEAD(&cifs_inode->openFileList);
325 return &cifs_inode->vfs_inode;
328 static void
329 cifs_destroy_inode(struct inode *inode)
331 kmem_cache_free(cifs_inode_cachep, CIFS_I(inode));
335 * cifs_show_options() is for displaying mount options in /proc/mounts.
336 * Not all settable options are displayed but most of the important
337 * ones are.
339 static int
340 cifs_show_options(struct seq_file *s, struct vfsmount *m)
342 struct cifs_sb_info *cifs_sb;
343 struct cifsTconInfo *tcon;
344 struct TCP_Server_Info *server;
346 cifs_sb = CIFS_SB(m->mnt_sb);
348 if (cifs_sb) {
349 tcon = cifs_sb->tcon;
350 if (tcon) {
351 seq_printf(s, ",unc=%s", cifs_sb->tcon->treeName);
352 if (tcon->ses) {
353 if (tcon->ses->userName)
354 seq_printf(s, ",username=%s",
355 tcon->ses->userName);
356 if (tcon->ses->domainName)
357 seq_printf(s, ",domain=%s",
358 tcon->ses->domainName);
359 server = tcon->ses->server;
360 if (server) {
361 seq_printf(s, ",addr=");
362 switch (server->addr.sockAddr6.
363 sin6_family) {
364 case AF_INET6:
365 seq_printf(s, "%pI6",
366 &server->addr.sockAddr6.sin6_addr);
367 break;
368 case AF_INET:
369 seq_printf(s, "%pI4",
370 &server->addr.sockAddr.sin_addr.s_addr);
371 break;
375 if ((cifs_sb->mnt_cifs_flags & CIFS_MOUNT_OVERR_UID) ||
376 !(tcon->unix_ext))
377 seq_printf(s, ",uid=%d", cifs_sb->mnt_uid);
378 if ((cifs_sb->mnt_cifs_flags & CIFS_MOUNT_OVERR_GID) ||
379 !(tcon->unix_ext))
380 seq_printf(s, ",gid=%d", cifs_sb->mnt_gid);
381 if (!tcon->unix_ext) {
382 seq_printf(s, ",file_mode=0%o,dir_mode=0%o",
383 cifs_sb->mnt_file_mode,
384 cifs_sb->mnt_dir_mode);
386 if (tcon->seal)
387 seq_printf(s, ",seal");
388 if (tcon->nocase)
389 seq_printf(s, ",nocase");
390 if (tcon->retry)
391 seq_printf(s, ",hard");
393 if (cifs_sb->prepath)
394 seq_printf(s, ",prepath=%s", cifs_sb->prepath);
395 if (cifs_sb->mnt_cifs_flags & CIFS_MOUNT_POSIX_PATHS)
396 seq_printf(s, ",posixpaths");
397 if (cifs_sb->mnt_cifs_flags & CIFS_MOUNT_SET_UID)
398 seq_printf(s, ",setuids");
399 if (cifs_sb->mnt_cifs_flags & CIFS_MOUNT_SERVER_INUM)
400 seq_printf(s, ",serverino");
401 if (cifs_sb->mnt_cifs_flags & CIFS_MOUNT_DIRECT_IO)
402 seq_printf(s, ",directio");
403 if (cifs_sb->mnt_cifs_flags & CIFS_MOUNT_NO_XATTR)
404 seq_printf(s, ",nouser_xattr");
405 if (cifs_sb->mnt_cifs_flags & CIFS_MOUNT_MAP_SPECIAL_CHR)
406 seq_printf(s, ",mapchars");
407 if (cifs_sb->mnt_cifs_flags & CIFS_MOUNT_UNX_EMUL)
408 seq_printf(s, ",sfu");
409 if (cifs_sb->mnt_cifs_flags & CIFS_MOUNT_NO_BRL)
410 seq_printf(s, ",nobrl");
411 if (cifs_sb->mnt_cifs_flags & CIFS_MOUNT_CIFS_ACL)
412 seq_printf(s, ",cifsacl");
413 if (cifs_sb->mnt_cifs_flags & CIFS_MOUNT_DYNPERM)
414 seq_printf(s, ",dynperm");
415 if (m->mnt_sb->s_flags & MS_POSIXACL)
416 seq_printf(s, ",acl");
418 seq_printf(s, ",rsize=%d", cifs_sb->rsize);
419 seq_printf(s, ",wsize=%d", cifs_sb->wsize);
421 return 0;
424 #ifdef CONFIG_CIFS_QUOTA
425 int cifs_xquota_set(struct super_block *sb, int quota_type, qid_t qid,
426 struct fs_disk_quota *pdquota)
428 int xid;
429 int rc = 0;
430 struct cifs_sb_info *cifs_sb = CIFS_SB(sb);
431 struct cifsTconInfo *pTcon;
433 if (cifs_sb)
434 pTcon = cifs_sb->tcon;
435 else
436 return -EIO;
439 xid = GetXid();
440 if (pTcon) {
441 cFYI(1, ("set type: 0x%x id: %d", quota_type, qid));
442 } else
443 rc = -EIO;
445 FreeXid(xid);
446 return rc;
449 int cifs_xquota_get(struct super_block *sb, int quota_type, qid_t qid,
450 struct fs_disk_quota *pdquota)
452 int xid;
453 int rc = 0;
454 struct cifs_sb_info *cifs_sb = CIFS_SB(sb);
455 struct cifsTconInfo *pTcon;
457 if (cifs_sb)
458 pTcon = cifs_sb->tcon;
459 else
460 return -EIO;
462 xid = GetXid();
463 if (pTcon) {
464 cFYI(1, ("set type: 0x%x id: %d", quota_type, qid));
465 } else
466 rc = -EIO;
468 FreeXid(xid);
469 return rc;
472 int cifs_xstate_set(struct super_block *sb, unsigned int flags, int operation)
474 int xid;
475 int rc = 0;
476 struct cifs_sb_info *cifs_sb = CIFS_SB(sb);
477 struct cifsTconInfo *pTcon;
479 if (cifs_sb)
480 pTcon = cifs_sb->tcon;
481 else
482 return -EIO;
484 xid = GetXid();
485 if (pTcon) {
486 cFYI(1, ("flags: 0x%x operation: 0x%x", flags, operation));
487 } else
488 rc = -EIO;
490 FreeXid(xid);
491 return rc;
494 int cifs_xstate_get(struct super_block *sb, struct fs_quota_stat *qstats)
496 int xid;
497 int rc = 0;
498 struct cifs_sb_info *cifs_sb = CIFS_SB(sb);
499 struct cifsTconInfo *pTcon;
501 if (cifs_sb)
502 pTcon = cifs_sb->tcon;
503 else
504 return -EIO;
506 xid = GetXid();
507 if (pTcon) {
508 cFYI(1, ("pqstats %p", qstats));
509 } else
510 rc = -EIO;
512 FreeXid(xid);
513 return rc;
516 static struct quotactl_ops cifs_quotactl_ops = {
517 .set_xquota = cifs_xquota_set,
518 .get_xquota = cifs_xquota_get,
519 .set_xstate = cifs_xstate_set,
520 .get_xstate = cifs_xstate_get,
522 #endif
524 static void cifs_umount_begin(struct super_block *sb)
526 struct cifs_sb_info *cifs_sb = CIFS_SB(sb);
527 struct cifsTconInfo *tcon;
529 if (cifs_sb == NULL)
530 return;
532 tcon = cifs_sb->tcon;
533 if (tcon == NULL)
534 return;
536 read_lock(&cifs_tcp_ses_lock);
537 if (tcon->tc_count == 1)
538 tcon->tidStatus = CifsExiting;
539 read_unlock(&cifs_tcp_ses_lock);
541 /* cancel_brl_requests(tcon); */ /* BB mark all brl mids as exiting */
542 /* cancel_notify_requests(tcon); */
543 if (tcon->ses && tcon->ses->server) {
544 cFYI(1, ("wake up tasks now - umount begin not complete"));
545 wake_up_all(&tcon->ses->server->request_q);
546 wake_up_all(&tcon->ses->server->response_q);
547 msleep(1); /* yield */
548 /* we have to kick the requests once more */
549 wake_up_all(&tcon->ses->server->response_q);
550 msleep(1);
552 /* BB FIXME - finish add checks for tidStatus BB */
554 return;
557 #ifdef CONFIG_CIFS_STATS2
558 static int cifs_show_stats(struct seq_file *s, struct vfsmount *mnt)
560 /* BB FIXME */
561 return 0;
563 #endif
565 static int cifs_remount(struct super_block *sb, int *flags, char *data)
567 *flags |= MS_NODIRATIME;
568 return 0;
571 static const struct super_operations cifs_super_ops = {
572 .put_super = cifs_put_super,
573 .statfs = cifs_statfs,
574 .alloc_inode = cifs_alloc_inode,
575 .destroy_inode = cifs_destroy_inode,
576 /* .drop_inode = generic_delete_inode,
577 .delete_inode = cifs_delete_inode, */ /* Do not need above two
578 functions unless later we add lazy close of inodes or unless the
579 kernel forgets to call us with the same number of releases (closes)
580 as opens */
581 .show_options = cifs_show_options,
582 .umount_begin = cifs_umount_begin,
583 .remount_fs = cifs_remount,
584 #ifdef CONFIG_CIFS_STATS2
585 .show_stats = cifs_show_stats,
586 #endif
589 static int
590 cifs_get_sb(struct file_system_type *fs_type,
591 int flags, const char *dev_name, void *data, struct vfsmount *mnt)
593 int rc;
594 struct super_block *sb = sget(fs_type, NULL, set_anon_super, NULL);
596 cFYI(1, ("Devname: %s flags: %d ", dev_name, flags));
598 if (IS_ERR(sb))
599 return PTR_ERR(sb);
601 sb->s_flags = flags;
603 rc = cifs_read_super(sb, data, dev_name, flags & MS_SILENT ? 1 : 0);
604 if (rc) {
605 up_write(&sb->s_umount);
606 deactivate_super(sb);
607 return rc;
609 sb->s_flags |= MS_ACTIVE;
610 simple_set_mnt(mnt, sb);
611 return 0;
614 static ssize_t cifs_file_aio_write(struct kiocb *iocb, const struct iovec *iov,
615 unsigned long nr_segs, loff_t pos)
617 struct inode *inode = iocb->ki_filp->f_path.dentry->d_inode;
618 ssize_t written;
620 written = generic_file_aio_write(iocb, iov, nr_segs, pos);
621 if (!CIFS_I(inode)->clientCanCacheAll)
622 filemap_fdatawrite(inode->i_mapping);
623 return written;
626 static loff_t cifs_llseek(struct file *file, loff_t offset, int origin)
628 /* origin == SEEK_END => we must revalidate the cached file length */
629 if (origin == SEEK_END) {
630 int retval;
632 /* some applications poll for the file length in this strange
633 way so we must seek to end on non-oplocked files by
634 setting the revalidate time to zero */
635 CIFS_I(file->f_path.dentry->d_inode)->time = 0;
637 retval = cifs_revalidate(file->f_path.dentry);
638 if (retval < 0)
639 return (loff_t)retval;
641 return generic_file_llseek_unlocked(file, offset, origin);
644 #ifdef CONFIG_CIFS_EXPERIMENTAL
645 static int cifs_setlease(struct file *file, long arg, struct file_lock **lease)
647 /* note that this is called by vfs setlease with the BKL held
648 although I doubt that BKL is needed here in cifs */
649 struct inode *inode = file->f_path.dentry->d_inode;
651 if (!(S_ISREG(inode->i_mode)))
652 return -EINVAL;
654 /* check if file is oplocked */
655 if (((arg == F_RDLCK) &&
656 (CIFS_I(inode)->clientCanCacheRead)) ||
657 ((arg == F_WRLCK) &&
658 (CIFS_I(inode)->clientCanCacheAll)))
659 return generic_setlease(file, arg, lease);
660 else if (CIFS_SB(inode->i_sb)->tcon->local_lease &&
661 !CIFS_I(inode)->clientCanCacheRead)
662 /* If the server claims to support oplock on this
663 file, then we still need to check oplock even
664 if the local_lease mount option is set, but there
665 are servers which do not support oplock for which
666 this mount option may be useful if the user
667 knows that the file won't be changed on the server
668 by anyone else */
669 return generic_setlease(file, arg, lease);
670 else
671 return -EAGAIN;
673 #endif
675 struct file_system_type cifs_fs_type = {
676 .owner = THIS_MODULE,
677 .name = "cifs",
678 .get_sb = cifs_get_sb,
679 .kill_sb = kill_anon_super,
680 /* .fs_flags */
682 const struct inode_operations cifs_dir_inode_ops = {
683 .create = cifs_create,
684 .lookup = cifs_lookup,
685 .getattr = cifs_getattr,
686 .unlink = cifs_unlink,
687 .link = cifs_hardlink,
688 .mkdir = cifs_mkdir,
689 .rmdir = cifs_rmdir,
690 .rename = cifs_rename,
691 .permission = cifs_permission,
692 /* revalidate:cifs_revalidate, */
693 .setattr = cifs_setattr,
694 .symlink = cifs_symlink,
695 .mknod = cifs_mknod,
696 #ifdef CONFIG_CIFS_XATTR
697 .setxattr = cifs_setxattr,
698 .getxattr = cifs_getxattr,
699 .listxattr = cifs_listxattr,
700 .removexattr = cifs_removexattr,
701 #endif
704 const struct inode_operations cifs_file_inode_ops = {
705 /* revalidate:cifs_revalidate, */
706 .setattr = cifs_setattr,
707 .getattr = cifs_getattr, /* do we need this anymore? */
708 .rename = cifs_rename,
709 .permission = cifs_permission,
710 #ifdef CONFIG_CIFS_XATTR
711 .setxattr = cifs_setxattr,
712 .getxattr = cifs_getxattr,
713 .listxattr = cifs_listxattr,
714 .removexattr = cifs_removexattr,
715 #endif
718 const struct inode_operations cifs_symlink_inode_ops = {
719 .readlink = generic_readlink,
720 .follow_link = cifs_follow_link,
721 .put_link = cifs_put_link,
722 .permission = cifs_permission,
723 /* BB add the following two eventually */
724 /* revalidate: cifs_revalidate,
725 setattr: cifs_notify_change, *//* BB do we need notify change */
726 #ifdef CONFIG_CIFS_XATTR
727 .setxattr = cifs_setxattr,
728 .getxattr = cifs_getxattr,
729 .listxattr = cifs_listxattr,
730 .removexattr = cifs_removexattr,
731 #endif
734 const struct file_operations cifs_file_ops = {
735 .read = do_sync_read,
736 .write = do_sync_write,
737 .aio_read = generic_file_aio_read,
738 .aio_write = cifs_file_aio_write,
739 .open = cifs_open,
740 .release = cifs_close,
741 .lock = cifs_lock,
742 .fsync = cifs_fsync,
743 .flush = cifs_flush,
744 .mmap = cifs_file_mmap,
745 .splice_read = generic_file_splice_read,
746 .llseek = cifs_llseek,
747 #ifdef CONFIG_CIFS_POSIX
748 .unlocked_ioctl = cifs_ioctl,
749 #endif /* CONFIG_CIFS_POSIX */
751 #ifdef CONFIG_CIFS_EXPERIMENTAL
752 .setlease = cifs_setlease,
753 #endif /* CONFIG_CIFS_EXPERIMENTAL */
756 const struct file_operations cifs_file_direct_ops = {
757 /* no mmap, no aio, no readv -
758 BB reevaluate whether they can be done with directio, no cache */
759 .read = cifs_user_read,
760 .write = cifs_user_write,
761 .open = cifs_open,
762 .release = cifs_close,
763 .lock = cifs_lock,
764 .fsync = cifs_fsync,
765 .flush = cifs_flush,
766 .splice_read = generic_file_splice_read,
767 #ifdef CONFIG_CIFS_POSIX
768 .unlocked_ioctl = cifs_ioctl,
769 #endif /* CONFIG_CIFS_POSIX */
770 .llseek = cifs_llseek,
771 #ifdef CONFIG_CIFS_EXPERIMENTAL
772 .setlease = cifs_setlease,
773 #endif /* CONFIG_CIFS_EXPERIMENTAL */
775 const struct file_operations cifs_file_nobrl_ops = {
776 .read = do_sync_read,
777 .write = do_sync_write,
778 .aio_read = generic_file_aio_read,
779 .aio_write = cifs_file_aio_write,
780 .open = cifs_open,
781 .release = cifs_close,
782 .fsync = cifs_fsync,
783 .flush = cifs_flush,
784 .mmap = cifs_file_mmap,
785 .splice_read = generic_file_splice_read,
786 .llseek = cifs_llseek,
787 #ifdef CONFIG_CIFS_POSIX
788 .unlocked_ioctl = cifs_ioctl,
789 #endif /* CONFIG_CIFS_POSIX */
791 #ifdef CONFIG_CIFS_EXPERIMENTAL
792 .setlease = cifs_setlease,
793 #endif /* CONFIG_CIFS_EXPERIMENTAL */
796 const struct file_operations cifs_file_direct_nobrl_ops = {
797 /* no mmap, no aio, no readv -
798 BB reevaluate whether they can be done with directio, no cache */
799 .read = cifs_user_read,
800 .write = cifs_user_write,
801 .open = cifs_open,
802 .release = cifs_close,
803 .fsync = cifs_fsync,
804 .flush = cifs_flush,
805 .splice_read = generic_file_splice_read,
806 #ifdef CONFIG_CIFS_POSIX
807 .unlocked_ioctl = cifs_ioctl,
808 #endif /* CONFIG_CIFS_POSIX */
809 .llseek = cifs_llseek,
810 #ifdef CONFIG_CIFS_EXPERIMENTAL
811 .setlease = cifs_setlease,
812 #endif /* CONFIG_CIFS_EXPERIMENTAL */
815 const struct file_operations cifs_dir_ops = {
816 .readdir = cifs_readdir,
817 .release = cifs_closedir,
818 .read = generic_read_dir,
819 .unlocked_ioctl = cifs_ioctl,
820 .llseek = generic_file_llseek,
823 static void
824 cifs_init_once(void *inode)
826 struct cifsInodeInfo *cifsi = inode;
828 inode_init_once(&cifsi->vfs_inode);
829 INIT_LIST_HEAD(&cifsi->lockList);
832 static int
833 cifs_init_inodecache(void)
835 cifs_inode_cachep = kmem_cache_create("cifs_inode_cache",
836 sizeof(struct cifsInodeInfo),
837 0, (SLAB_RECLAIM_ACCOUNT|
838 SLAB_MEM_SPREAD),
839 cifs_init_once);
840 if (cifs_inode_cachep == NULL)
841 return -ENOMEM;
843 return 0;
846 static void
847 cifs_destroy_inodecache(void)
849 kmem_cache_destroy(cifs_inode_cachep);
852 static int
853 cifs_init_request_bufs(void)
855 if (CIFSMaxBufSize < 8192) {
856 /* Buffer size can not be smaller than 2 * PATH_MAX since maximum
857 Unicode path name has to fit in any SMB/CIFS path based frames */
858 CIFSMaxBufSize = 8192;
859 } else if (CIFSMaxBufSize > 1024*127) {
860 CIFSMaxBufSize = 1024 * 127;
861 } else {
862 CIFSMaxBufSize &= 0x1FE00; /* Round size to even 512 byte mult*/
864 /* cERROR(1,("CIFSMaxBufSize %d 0x%x",CIFSMaxBufSize,CIFSMaxBufSize)); */
865 cifs_req_cachep = kmem_cache_create("cifs_request",
866 CIFSMaxBufSize +
867 MAX_CIFS_HDR_SIZE, 0,
868 SLAB_HWCACHE_ALIGN, NULL);
869 if (cifs_req_cachep == NULL)
870 return -ENOMEM;
872 if (cifs_min_rcv < 1)
873 cifs_min_rcv = 1;
874 else if (cifs_min_rcv > 64) {
875 cifs_min_rcv = 64;
876 cERROR(1, ("cifs_min_rcv set to maximum (64)"));
879 cifs_req_poolp = mempool_create_slab_pool(cifs_min_rcv,
880 cifs_req_cachep);
882 if (cifs_req_poolp == NULL) {
883 kmem_cache_destroy(cifs_req_cachep);
884 return -ENOMEM;
886 /* MAX_CIFS_SMALL_BUFFER_SIZE bytes is enough for most SMB responses and
887 almost all handle based requests (but not write response, nor is it
888 sufficient for path based requests). A smaller size would have
889 been more efficient (compacting multiple slab items on one 4k page)
890 for the case in which debug was on, but this larger size allows
891 more SMBs to use small buffer alloc and is still much more
892 efficient to alloc 1 per page off the slab compared to 17K (5page)
893 alloc of large cifs buffers even when page debugging is on */
894 cifs_sm_req_cachep = kmem_cache_create("cifs_small_rq",
895 MAX_CIFS_SMALL_BUFFER_SIZE, 0, SLAB_HWCACHE_ALIGN,
896 NULL);
897 if (cifs_sm_req_cachep == NULL) {
898 mempool_destroy(cifs_req_poolp);
899 kmem_cache_destroy(cifs_req_cachep);
900 return -ENOMEM;
903 if (cifs_min_small < 2)
904 cifs_min_small = 2;
905 else if (cifs_min_small > 256) {
906 cifs_min_small = 256;
907 cFYI(1, ("cifs_min_small set to maximum (256)"));
910 cifs_sm_req_poolp = mempool_create_slab_pool(cifs_min_small,
911 cifs_sm_req_cachep);
913 if (cifs_sm_req_poolp == NULL) {
914 mempool_destroy(cifs_req_poolp);
915 kmem_cache_destroy(cifs_req_cachep);
916 kmem_cache_destroy(cifs_sm_req_cachep);
917 return -ENOMEM;
920 return 0;
923 static void
924 cifs_destroy_request_bufs(void)
926 mempool_destroy(cifs_req_poolp);
927 kmem_cache_destroy(cifs_req_cachep);
928 mempool_destroy(cifs_sm_req_poolp);
929 kmem_cache_destroy(cifs_sm_req_cachep);
932 static int
933 cifs_init_mids(void)
935 cifs_mid_cachep = kmem_cache_create("cifs_mpx_ids",
936 sizeof(struct mid_q_entry), 0,
937 SLAB_HWCACHE_ALIGN, NULL);
938 if (cifs_mid_cachep == NULL)
939 return -ENOMEM;
941 /* 3 is a reasonable minimum number of simultaneous operations */
942 cifs_mid_poolp = mempool_create_slab_pool(3, cifs_mid_cachep);
943 if (cifs_mid_poolp == NULL) {
944 kmem_cache_destroy(cifs_mid_cachep);
945 return -ENOMEM;
948 cifs_oplock_cachep = kmem_cache_create("cifs_oplock_structs",
949 sizeof(struct oplock_q_entry), 0,
950 SLAB_HWCACHE_ALIGN, NULL);
951 if (cifs_oplock_cachep == NULL) {
952 mempool_destroy(cifs_mid_poolp);
953 kmem_cache_destroy(cifs_mid_cachep);
954 return -ENOMEM;
957 return 0;
960 static void
961 cifs_destroy_mids(void)
963 mempool_destroy(cifs_mid_poolp);
964 kmem_cache_destroy(cifs_mid_cachep);
965 kmem_cache_destroy(cifs_oplock_cachep);
968 static int cifs_oplock_thread(void *dummyarg)
970 struct oplock_q_entry *oplock_item;
971 struct cifsTconInfo *pTcon;
972 struct inode *inode;
973 __u16 netfid;
974 int rc, waitrc = 0;
976 set_freezable();
977 do {
978 if (try_to_freeze())
979 continue;
981 spin_lock(&GlobalMid_Lock);
982 if (list_empty(&GlobalOplock_Q)) {
983 spin_unlock(&GlobalMid_Lock);
984 set_current_state(TASK_INTERRUPTIBLE);
985 schedule_timeout(39*HZ);
986 } else {
987 oplock_item = list_entry(GlobalOplock_Q.next,
988 struct oplock_q_entry, qhead);
989 cFYI(1, ("found oplock item to write out"));
990 pTcon = oplock_item->tcon;
991 inode = oplock_item->pinode;
992 netfid = oplock_item->netfid;
993 spin_unlock(&GlobalMid_Lock);
994 DeleteOplockQEntry(oplock_item);
995 /* can not grab inode sem here since it would
996 deadlock when oplock received on delete
997 since vfs_unlink holds the i_mutex across
998 the call */
999 /* mutex_lock(&inode->i_mutex);*/
1000 if (S_ISREG(inode->i_mode)) {
1001 #ifdef CONFIG_CIFS_EXPERIMENTAL
1002 if (CIFS_I(inode)->clientCanCacheAll == 0)
1003 break_lease(inode, FMODE_READ);
1004 else if (CIFS_I(inode)->clientCanCacheRead == 0)
1005 break_lease(inode, FMODE_WRITE);
1006 #endif
1007 rc = filemap_fdatawrite(inode->i_mapping);
1008 if (CIFS_I(inode)->clientCanCacheRead == 0) {
1009 waitrc = filemap_fdatawait(
1010 inode->i_mapping);
1011 invalidate_remote_inode(inode);
1013 if (rc == 0)
1014 rc = waitrc;
1015 } else
1016 rc = 0;
1017 /* mutex_unlock(&inode->i_mutex);*/
1018 if (rc)
1019 CIFS_I(inode)->write_behind_rc = rc;
1020 cFYI(1, ("Oplock flush inode %p rc %d",
1021 inode, rc));
1023 /* releasing stale oplock after recent reconnect
1024 of smb session using a now incorrect file
1025 handle is not a data integrity issue but do
1026 not bother sending an oplock release if session
1027 to server still is disconnected since oplock
1028 already released by the server in that case */
1029 if (!pTcon->need_reconnect) {
1030 rc = CIFSSMBLock(0, pTcon, netfid,
1031 0 /* len */ , 0 /* offset */, 0,
1032 0, LOCKING_ANDX_OPLOCK_RELEASE,
1033 false /* wait flag */);
1034 cFYI(1, ("Oplock release rc = %d", rc));
1036 set_current_state(TASK_INTERRUPTIBLE);
1037 schedule_timeout(1); /* yield in case q were corrupt */
1039 } while (!kthread_should_stop());
1041 return 0;
1044 #ifdef CONFIG_CIFS_EXPERIMENTAL
1045 static int cifs_dnotify_thread(void *dummyarg)
1047 struct list_head *tmp;
1048 struct TCP_Server_Info *server;
1050 do {
1051 if (try_to_freeze())
1052 continue;
1053 set_current_state(TASK_INTERRUPTIBLE);
1054 schedule_timeout(15*HZ);
1055 /* check if any stuck requests that need
1056 to be woken up and wakeq so the
1057 thread can wake up and error out */
1058 read_lock(&cifs_tcp_ses_lock);
1059 list_for_each(tmp, &cifs_tcp_ses_list) {
1060 server = list_entry(tmp, struct TCP_Server_Info,
1061 tcp_ses_list);
1062 if (atomic_read(&server->inFlight))
1063 wake_up_all(&server->response_q);
1065 read_unlock(&cifs_tcp_ses_lock);
1066 } while (!kthread_should_stop());
1068 return 0;
1070 #endif
1072 static int __init
1073 init_cifs(void)
1075 int rc = 0;
1076 cifs_proc_init();
1077 INIT_LIST_HEAD(&cifs_tcp_ses_list);
1078 INIT_LIST_HEAD(&GlobalOplock_Q);
1079 #ifdef CONFIG_CIFS_EXPERIMENTAL
1080 INIT_LIST_HEAD(&GlobalDnotifyReqList);
1081 INIT_LIST_HEAD(&GlobalDnotifyRsp_Q);
1082 #endif
1084 * Initialize Global counters
1086 atomic_set(&sesInfoAllocCount, 0);
1087 atomic_set(&tconInfoAllocCount, 0);
1088 atomic_set(&tcpSesAllocCount, 0);
1089 atomic_set(&tcpSesReconnectCount, 0);
1090 atomic_set(&tconInfoReconnectCount, 0);
1092 atomic_set(&bufAllocCount, 0);
1093 atomic_set(&smBufAllocCount, 0);
1094 #ifdef CONFIG_CIFS_STATS2
1095 atomic_set(&totBufAllocCount, 0);
1096 atomic_set(&totSmBufAllocCount, 0);
1097 #endif /* CONFIG_CIFS_STATS2 */
1099 atomic_set(&midCount, 0);
1100 GlobalCurrentXid = 0;
1101 GlobalTotalActiveXid = 0;
1102 GlobalMaxActiveXid = 0;
1103 memset(Local_System_Name, 0, 15);
1104 rwlock_init(&GlobalSMBSeslock);
1105 rwlock_init(&cifs_tcp_ses_lock);
1106 spin_lock_init(&GlobalMid_Lock);
1108 if (cifs_max_pending < 2) {
1109 cifs_max_pending = 2;
1110 cFYI(1, ("cifs_max_pending set to min of 2"));
1111 } else if (cifs_max_pending > 256) {
1112 cifs_max_pending = 256;
1113 cFYI(1, ("cifs_max_pending set to max of 256"));
1116 rc = cifs_init_inodecache();
1117 if (rc)
1118 goto out_clean_proc;
1120 rc = cifs_init_mids();
1121 if (rc)
1122 goto out_destroy_inodecache;
1124 rc = cifs_init_request_bufs();
1125 if (rc)
1126 goto out_destroy_mids;
1128 rc = register_filesystem(&cifs_fs_type);
1129 if (rc)
1130 goto out_destroy_request_bufs;
1131 #ifdef CONFIG_CIFS_UPCALL
1132 rc = register_key_type(&cifs_spnego_key_type);
1133 if (rc)
1134 goto out_unregister_filesystem;
1135 #endif
1136 #ifdef CONFIG_CIFS_DFS_UPCALL
1137 rc = register_key_type(&key_type_dns_resolver);
1138 if (rc)
1139 goto out_unregister_key_type;
1140 #endif
1141 oplockThread = kthread_run(cifs_oplock_thread, NULL, "cifsoplockd");
1142 if (IS_ERR(oplockThread)) {
1143 rc = PTR_ERR(oplockThread);
1144 cERROR(1, ("error %d create oplock thread", rc));
1145 goto out_unregister_dfs_key_type;
1148 #ifdef CONFIG_CIFS_EXPERIMENTAL
1149 dnotifyThread = kthread_run(cifs_dnotify_thread, NULL, "cifsdnotifyd");
1150 if (IS_ERR(dnotifyThread)) {
1151 rc = PTR_ERR(dnotifyThread);
1152 cERROR(1, ("error %d create dnotify thread", rc));
1153 goto out_stop_oplock_thread;
1155 #endif
1157 return 0;
1159 #ifdef CONFIG_CIFS_EXPERIMENTAL
1160 out_stop_oplock_thread:
1161 #endif
1162 kthread_stop(oplockThread);
1163 out_unregister_dfs_key_type:
1164 #ifdef CONFIG_CIFS_DFS_UPCALL
1165 unregister_key_type(&key_type_dns_resolver);
1166 out_unregister_key_type:
1167 #endif
1168 #ifdef CONFIG_CIFS_UPCALL
1169 unregister_key_type(&cifs_spnego_key_type);
1170 out_unregister_filesystem:
1171 #endif
1172 unregister_filesystem(&cifs_fs_type);
1173 out_destroy_request_bufs:
1174 cifs_destroy_request_bufs();
1175 out_destroy_mids:
1176 cifs_destroy_mids();
1177 out_destroy_inodecache:
1178 cifs_destroy_inodecache();
1179 out_clean_proc:
1180 cifs_proc_clean();
1181 return rc;
1184 static void __exit
1185 exit_cifs(void)
1187 cFYI(DBG2, ("exit_cifs"));
1188 cifs_proc_clean();
1189 #ifdef CONFIG_CIFS_DFS_UPCALL
1190 cifs_dfs_release_automount_timer();
1191 unregister_key_type(&key_type_dns_resolver);
1192 #endif
1193 #ifdef CONFIG_CIFS_UPCALL
1194 unregister_key_type(&cifs_spnego_key_type);
1195 #endif
1196 unregister_filesystem(&cifs_fs_type);
1197 cifs_destroy_inodecache();
1198 cifs_destroy_mids();
1199 cifs_destroy_request_bufs();
1200 #ifdef CONFIG_CIFS_EXPERIMENTAL
1201 kthread_stop(dnotifyThread);
1202 #endif
1203 kthread_stop(oplockThread);
1206 MODULE_AUTHOR("Steve French <sfrench@us.ibm.com>");
1207 MODULE_LICENSE("GPL"); /* combination of LGPL + GPL source behaves as GPL */
1208 MODULE_DESCRIPTION
1209 ("VFS to access servers complying with the SNIA CIFS Specification "
1210 "e.g. Samba and Windows");
1211 MODULE_VERSION(CIFS_VERSION);
1212 module_init(init_cifs)
1213 module_exit(exit_cifs)