cifs: implement i_op->atomic_open()
[deliverable/linux.git] / fs / cifs / cifsfs.c
1 /*
2 * fs/cifs/cifsfs.c
3 *
4 * Copyright (C) International Business Machines Corp., 2002,2008
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 <linux/namei.h>
39 #include <net/ipv6.h>
40 #include "cifsfs.h"
41 #include "cifspdu.h"
42 #define DECLARE_GLOBALS_HERE
43 #include "cifsglob.h"
44 #include "cifsproto.h"
45 #include "cifs_debug.h"
46 #include "cifs_fs_sb.h"
47 #include <linux/mm.h>
48 #include <linux/key-type.h>
49 #include "cifs_spnego.h"
50 #include "fscache.h"
51 #define CIFS_MAGIC_NUMBER 0xFF534D42 /* the first four bytes of SMB PDUs */
52
53 int cifsFYI = 0;
54 int cifsERROR = 1;
55 int traceSMB = 0;
56 bool enable_oplocks = true;
57 unsigned int linuxExtEnabled = 1;
58 unsigned int lookupCacheEnabled = 1;
59 unsigned int global_secflags = CIFSSEC_DEF;
60 /* unsigned int ntlmv2_support = 0; */
61 unsigned int sign_CIFS_PDUs = 1;
62 static const struct super_operations cifs_super_ops;
63 unsigned int CIFSMaxBufSize = CIFS_MAX_MSGSIZE;
64 module_param(CIFSMaxBufSize, int, 0);
65 MODULE_PARM_DESC(CIFSMaxBufSize, "Network buffer size (not including header). "
66 "Default: 16384 Range: 8192 to 130048");
67 unsigned int cifs_min_rcv = CIFS_MIN_RCV_POOL;
68 module_param(cifs_min_rcv, int, 0);
69 MODULE_PARM_DESC(cifs_min_rcv, "Network buffers in pool. Default: 4 Range: "
70 "1 to 64");
71 unsigned int cifs_min_small = 30;
72 module_param(cifs_min_small, int, 0);
73 MODULE_PARM_DESC(cifs_min_small, "Small network buffers in pool. Default: 30 "
74 "Range: 2 to 256");
75 unsigned int cifs_max_pending = CIFS_MAX_REQ;
76 module_param(cifs_max_pending, int, 0444);
77 MODULE_PARM_DESC(cifs_max_pending, "Simultaneous requests to server. "
78 "Default: 32767 Range: 2 to 32767.");
79 module_param(enable_oplocks, bool, 0644);
80 MODULE_PARM_DESC(enable_oplocks, "Enable or disable oplocks (bool). Default:"
81 "y/Y/1");
82
83 extern mempool_t *cifs_sm_req_poolp;
84 extern mempool_t *cifs_req_poolp;
85 extern mempool_t *cifs_mid_poolp;
86
87 struct workqueue_struct *cifsiod_wq;
88
89 static int
90 cifs_read_super(struct super_block *sb)
91 {
92 struct inode *inode;
93 struct cifs_sb_info *cifs_sb;
94 int rc = 0;
95
96 cifs_sb = CIFS_SB(sb);
97
98 if (cifs_sb->mnt_cifs_flags & CIFS_MOUNT_POSIXACL)
99 sb->s_flags |= MS_POSIXACL;
100
101 if (cifs_sb_master_tcon(cifs_sb)->ses->capabilities & CAP_LARGE_FILES)
102 sb->s_maxbytes = MAX_LFS_FILESIZE;
103 else
104 sb->s_maxbytes = MAX_NON_LFS;
105
106 /* BB FIXME fix time_gran to be larger for LANMAN sessions */
107 sb->s_time_gran = 100;
108
109 sb->s_magic = CIFS_MAGIC_NUMBER;
110 sb->s_op = &cifs_super_ops;
111 sb->s_bdi = &cifs_sb->bdi;
112 sb->s_blocksize = CIFS_MAX_MSGSIZE;
113 sb->s_blocksize_bits = 14; /* default 2**14 = CIFS_MAX_MSGSIZE */
114 inode = cifs_root_iget(sb);
115
116 if (IS_ERR(inode)) {
117 rc = PTR_ERR(inode);
118 goto out_no_root;
119 }
120
121 sb->s_root = d_make_root(inode);
122 if (!sb->s_root) {
123 rc = -ENOMEM;
124 goto out_no_root;
125 }
126
127 /* do that *after* d_make_root() - we want NULL ->d_op for root here */
128 if (cifs_sb_master_tcon(cifs_sb)->nocase)
129 sb->s_d_op = &cifs_ci_dentry_ops;
130 else
131 sb->s_d_op = &cifs_dentry_ops;
132
133 #ifdef CONFIG_CIFS_NFSD_EXPORT
134 if (cifs_sb->mnt_cifs_flags & CIFS_MOUNT_SERVER_INUM) {
135 cFYI(1, "export ops supported");
136 sb->s_export_op = &cifs_export_ops;
137 }
138 #endif /* CONFIG_CIFS_NFSD_EXPORT */
139
140 return 0;
141
142 out_no_root:
143 cERROR(1, "cifs_read_super: get root inode failed");
144 return rc;
145 }
146
147 static void cifs_kill_sb(struct super_block *sb)
148 {
149 struct cifs_sb_info *cifs_sb = CIFS_SB(sb);
150 kill_anon_super(sb);
151 cifs_umount(cifs_sb);
152 }
153
154 static int
155 cifs_statfs(struct dentry *dentry, struct kstatfs *buf)
156 {
157 struct super_block *sb = dentry->d_sb;
158 struct cifs_sb_info *cifs_sb = CIFS_SB(sb);
159 struct cifs_tcon *tcon = cifs_sb_master_tcon(cifs_sb);
160 int rc = -EOPNOTSUPP;
161 int xid;
162
163 xid = GetXid();
164
165 buf->f_type = CIFS_MAGIC_NUMBER;
166
167 /*
168 * PATH_MAX may be too long - it would presumably be total path,
169 * but note that some servers (includinng Samba 3) have a shorter
170 * maximum path.
171 *
172 * Instead could get the real value via SMB_QUERY_FS_ATTRIBUTE_INFO.
173 */
174 buf->f_namelen = PATH_MAX;
175 buf->f_files = 0; /* undefined */
176 buf->f_ffree = 0; /* unlimited */
177
178 /*
179 * We could add a second check for a QFS Unix capability bit
180 */
181 if ((tcon->ses->capabilities & CAP_UNIX) &&
182 (CIFS_POSIX_EXTENSIONS & le64_to_cpu(tcon->fsUnixInfo.Capability)))
183 rc = CIFSSMBQFSPosixInfo(xid, tcon, buf);
184
185 /*
186 * Only need to call the old QFSInfo if failed on newer one,
187 * e.g. by OS/2.
188 **/
189 if (rc && (tcon->ses->capabilities & CAP_NT_SMBS))
190 rc = CIFSSMBQFSInfo(xid, tcon, buf);
191
192 /*
193 * Some old Windows servers also do not support level 103, retry with
194 * older level one if old server failed the previous call or we
195 * bypassed it because we detected that this was an older LANMAN sess
196 */
197 if (rc)
198 rc = SMBOldQFSInfo(xid, tcon, buf);
199
200 FreeXid(xid);
201 return 0;
202 }
203
204 static int cifs_permission(struct inode *inode, int mask)
205 {
206 struct cifs_sb_info *cifs_sb;
207
208 cifs_sb = CIFS_SB(inode->i_sb);
209
210 if (cifs_sb->mnt_cifs_flags & CIFS_MOUNT_NO_PERM) {
211 if ((mask & MAY_EXEC) && !execute_ok(inode))
212 return -EACCES;
213 else
214 return 0;
215 } else /* file mode might have been restricted at mount time
216 on the client (above and beyond ACL on servers) for
217 servers which do not support setting and viewing mode bits,
218 so allowing client to check permissions is useful */
219 return generic_permission(inode, mask);
220 }
221
222 static struct kmem_cache *cifs_inode_cachep;
223 static struct kmem_cache *cifs_req_cachep;
224 static struct kmem_cache *cifs_mid_cachep;
225 static struct kmem_cache *cifs_sm_req_cachep;
226 mempool_t *cifs_sm_req_poolp;
227 mempool_t *cifs_req_poolp;
228 mempool_t *cifs_mid_poolp;
229
230 static struct inode *
231 cifs_alloc_inode(struct super_block *sb)
232 {
233 struct cifsInodeInfo *cifs_inode;
234 cifs_inode = kmem_cache_alloc(cifs_inode_cachep, GFP_KERNEL);
235 if (!cifs_inode)
236 return NULL;
237 cifs_inode->cifsAttrs = 0x20; /* default */
238 cifs_inode->time = 0;
239 /* Until the file is open and we have gotten oplock
240 info back from the server, can not assume caching of
241 file data or metadata */
242 cifs_set_oplock_level(cifs_inode, 0);
243 cifs_inode->delete_pending = false;
244 cifs_inode->invalid_mapping = false;
245 cifs_inode->vfs_inode.i_blkbits = 14; /* 2**14 = CIFS_MAX_MSGSIZE */
246 cifs_inode->server_eof = 0;
247 cifs_inode->uniqueid = 0;
248 cifs_inode->createtime = 0;
249
250 /* Can not set i_flags here - they get immediately overwritten
251 to zero by the VFS */
252 /* cifs_inode->vfs_inode.i_flags = S_NOATIME | S_NOCMTIME;*/
253 INIT_LIST_HEAD(&cifs_inode->openFileList);
254 return &cifs_inode->vfs_inode;
255 }
256
257 static void cifs_i_callback(struct rcu_head *head)
258 {
259 struct inode *inode = container_of(head, struct inode, i_rcu);
260 kmem_cache_free(cifs_inode_cachep, CIFS_I(inode));
261 }
262
263 static void
264 cifs_destroy_inode(struct inode *inode)
265 {
266 call_rcu(&inode->i_rcu, cifs_i_callback);
267 }
268
269 static void
270 cifs_evict_inode(struct inode *inode)
271 {
272 truncate_inode_pages(&inode->i_data, 0);
273 clear_inode(inode);
274 cifs_fscache_release_inode_cookie(inode);
275 }
276
277 static void
278 cifs_show_address(struct seq_file *s, struct TCP_Server_Info *server)
279 {
280 struct sockaddr_in *sa = (struct sockaddr_in *) &server->dstaddr;
281 struct sockaddr_in6 *sa6 = (struct sockaddr_in6 *) &server->dstaddr;
282
283 seq_printf(s, ",addr=");
284
285 switch (server->dstaddr.ss_family) {
286 case AF_INET:
287 seq_printf(s, "%pI4", &sa->sin_addr.s_addr);
288 break;
289 case AF_INET6:
290 seq_printf(s, "%pI6", &sa6->sin6_addr.s6_addr);
291 if (sa6->sin6_scope_id)
292 seq_printf(s, "%%%u", sa6->sin6_scope_id);
293 break;
294 default:
295 seq_printf(s, "(unknown)");
296 }
297 }
298
299 static void
300 cifs_show_security(struct seq_file *s, struct TCP_Server_Info *server)
301 {
302 seq_printf(s, ",sec=");
303
304 switch (server->secType) {
305 case LANMAN:
306 seq_printf(s, "lanman");
307 break;
308 case NTLMv2:
309 seq_printf(s, "ntlmv2");
310 break;
311 case NTLM:
312 seq_printf(s, "ntlm");
313 break;
314 case Kerberos:
315 seq_printf(s, "krb5");
316 break;
317 case RawNTLMSSP:
318 seq_printf(s, "ntlmssp");
319 break;
320 default:
321 /* shouldn't ever happen */
322 seq_printf(s, "unknown");
323 break;
324 }
325
326 if (server->sec_mode & (SECMODE_SIGN_REQUIRED | SECMODE_SIGN_ENABLED))
327 seq_printf(s, "i");
328 }
329
330 static void
331 cifs_show_cache_flavor(struct seq_file *s, struct cifs_sb_info *cifs_sb)
332 {
333 seq_printf(s, ",cache=");
334
335 if (cifs_sb->mnt_cifs_flags & CIFS_MOUNT_STRICT_IO)
336 seq_printf(s, "strict");
337 else if (cifs_sb->mnt_cifs_flags & CIFS_MOUNT_DIRECT_IO)
338 seq_printf(s, "none");
339 else
340 seq_printf(s, "loose");
341 }
342
343 /*
344 * cifs_show_options() is for displaying mount options in /proc/mounts.
345 * Not all settable options are displayed but most of the important
346 * ones are.
347 */
348 static int
349 cifs_show_options(struct seq_file *s, struct dentry *root)
350 {
351 struct cifs_sb_info *cifs_sb = CIFS_SB(root->d_sb);
352 struct cifs_tcon *tcon = cifs_sb_master_tcon(cifs_sb);
353 struct sockaddr *srcaddr;
354 srcaddr = (struct sockaddr *)&tcon->ses->server->srcaddr;
355
356 seq_printf(s, ",vers=%s", tcon->ses->server->vals->version_string);
357 cifs_show_security(s, tcon->ses->server);
358 cifs_show_cache_flavor(s, cifs_sb);
359
360 seq_printf(s, ",unc=%s", tcon->treeName);
361
362 if (cifs_sb->mnt_cifs_flags & CIFS_MOUNT_MULTIUSER)
363 seq_printf(s, ",multiuser");
364 else if (tcon->ses->user_name)
365 seq_printf(s, ",username=%s", tcon->ses->user_name);
366
367 if (tcon->ses->domainName)
368 seq_printf(s, ",domain=%s", tcon->ses->domainName);
369
370 if (srcaddr->sa_family != AF_UNSPEC) {
371 struct sockaddr_in *saddr4;
372 struct sockaddr_in6 *saddr6;
373 saddr4 = (struct sockaddr_in *)srcaddr;
374 saddr6 = (struct sockaddr_in6 *)srcaddr;
375 if (srcaddr->sa_family == AF_INET6)
376 seq_printf(s, ",srcaddr=%pI6c",
377 &saddr6->sin6_addr);
378 else if (srcaddr->sa_family == AF_INET)
379 seq_printf(s, ",srcaddr=%pI4",
380 &saddr4->sin_addr.s_addr);
381 else
382 seq_printf(s, ",srcaddr=BAD-AF:%i",
383 (int)(srcaddr->sa_family));
384 }
385
386 seq_printf(s, ",uid=%u", cifs_sb->mnt_uid);
387 if (cifs_sb->mnt_cifs_flags & CIFS_MOUNT_OVERR_UID)
388 seq_printf(s, ",forceuid");
389 else
390 seq_printf(s, ",noforceuid");
391
392 seq_printf(s, ",gid=%u", cifs_sb->mnt_gid);
393 if (cifs_sb->mnt_cifs_flags & CIFS_MOUNT_OVERR_GID)
394 seq_printf(s, ",forcegid");
395 else
396 seq_printf(s, ",noforcegid");
397
398 cifs_show_address(s, tcon->ses->server);
399
400 if (!tcon->unix_ext)
401 seq_printf(s, ",file_mode=0%ho,dir_mode=0%ho",
402 cifs_sb->mnt_file_mode,
403 cifs_sb->mnt_dir_mode);
404 if (tcon->seal)
405 seq_printf(s, ",seal");
406 if (tcon->nocase)
407 seq_printf(s, ",nocase");
408 if (tcon->retry)
409 seq_printf(s, ",hard");
410 if (tcon->unix_ext)
411 seq_printf(s, ",unix");
412 else
413 seq_printf(s, ",nounix");
414 if (cifs_sb->mnt_cifs_flags & CIFS_MOUNT_POSIX_PATHS)
415 seq_printf(s, ",posixpaths");
416 if (cifs_sb->mnt_cifs_flags & CIFS_MOUNT_SET_UID)
417 seq_printf(s, ",setuids");
418 if (cifs_sb->mnt_cifs_flags & CIFS_MOUNT_SERVER_INUM)
419 seq_printf(s, ",serverino");
420 if (cifs_sb->mnt_cifs_flags & CIFS_MOUNT_RWPIDFORWARD)
421 seq_printf(s, ",rwpidforward");
422 if (cifs_sb->mnt_cifs_flags & CIFS_MOUNT_NOPOSIXBRL)
423 seq_printf(s, ",forcemand");
424 if (cifs_sb->mnt_cifs_flags & CIFS_MOUNT_NO_XATTR)
425 seq_printf(s, ",nouser_xattr");
426 if (cifs_sb->mnt_cifs_flags & CIFS_MOUNT_MAP_SPECIAL_CHR)
427 seq_printf(s, ",mapchars");
428 if (cifs_sb->mnt_cifs_flags & CIFS_MOUNT_UNX_EMUL)
429 seq_printf(s, ",sfu");
430 if (cifs_sb->mnt_cifs_flags & CIFS_MOUNT_NO_BRL)
431 seq_printf(s, ",nobrl");
432 if (cifs_sb->mnt_cifs_flags & CIFS_MOUNT_CIFS_ACL)
433 seq_printf(s, ",cifsacl");
434 if (cifs_sb->mnt_cifs_flags & CIFS_MOUNT_DYNPERM)
435 seq_printf(s, ",dynperm");
436 if (root->d_sb->s_flags & MS_POSIXACL)
437 seq_printf(s, ",acl");
438 if (cifs_sb->mnt_cifs_flags & CIFS_MOUNT_MF_SYMLINKS)
439 seq_printf(s, ",mfsymlinks");
440 if (cifs_sb->mnt_cifs_flags & CIFS_MOUNT_FSCACHE)
441 seq_printf(s, ",fsc");
442 if (cifs_sb->mnt_cifs_flags & CIFS_MOUNT_NOSSYNC)
443 seq_printf(s, ",nostrictsync");
444 if (cifs_sb->mnt_cifs_flags & CIFS_MOUNT_NO_PERM)
445 seq_printf(s, ",noperm");
446 if (cifs_sb->mnt_cifs_flags & CIFS_MOUNT_CIFS_BACKUPUID)
447 seq_printf(s, ",backupuid=%u", cifs_sb->mnt_backupuid);
448 if (cifs_sb->mnt_cifs_flags & CIFS_MOUNT_CIFS_BACKUPGID)
449 seq_printf(s, ",backupgid=%u", cifs_sb->mnt_backupgid);
450
451 seq_printf(s, ",rsize=%u", cifs_sb->rsize);
452 seq_printf(s, ",wsize=%u", cifs_sb->wsize);
453 /* convert actimeo and display it in seconds */
454 seq_printf(s, ",actimeo=%lu", cifs_sb->actimeo / HZ);
455
456 return 0;
457 }
458
459 static void cifs_umount_begin(struct super_block *sb)
460 {
461 struct cifs_sb_info *cifs_sb = CIFS_SB(sb);
462 struct cifs_tcon *tcon;
463
464 if (cifs_sb == NULL)
465 return;
466
467 tcon = cifs_sb_master_tcon(cifs_sb);
468
469 spin_lock(&cifs_tcp_ses_lock);
470 if ((tcon->tc_count > 1) || (tcon->tidStatus == CifsExiting)) {
471 /* we have other mounts to same share or we have
472 already tried to force umount this and woken up
473 all waiting network requests, nothing to do */
474 spin_unlock(&cifs_tcp_ses_lock);
475 return;
476 } else if (tcon->tc_count == 1)
477 tcon->tidStatus = CifsExiting;
478 spin_unlock(&cifs_tcp_ses_lock);
479
480 /* cancel_brl_requests(tcon); */ /* BB mark all brl mids as exiting */
481 /* cancel_notify_requests(tcon); */
482 if (tcon->ses && tcon->ses->server) {
483 cFYI(1, "wake up tasks now - umount begin not complete");
484 wake_up_all(&tcon->ses->server->request_q);
485 wake_up_all(&tcon->ses->server->response_q);
486 msleep(1); /* yield */
487 /* we have to kick the requests once more */
488 wake_up_all(&tcon->ses->server->response_q);
489 msleep(1);
490 }
491
492 return;
493 }
494
495 #ifdef CONFIG_CIFS_STATS2
496 static int cifs_show_stats(struct seq_file *s, struct dentry *root)
497 {
498 /* BB FIXME */
499 return 0;
500 }
501 #endif
502
503 static int cifs_remount(struct super_block *sb, int *flags, char *data)
504 {
505 *flags |= MS_NODIRATIME;
506 return 0;
507 }
508
509 static int cifs_drop_inode(struct inode *inode)
510 {
511 struct cifs_sb_info *cifs_sb = CIFS_SB(inode->i_sb);
512
513 /* no serverino => unconditional eviction */
514 return !(cifs_sb->mnt_cifs_flags & CIFS_MOUNT_SERVER_INUM) ||
515 generic_drop_inode(inode);
516 }
517
518 static const struct super_operations cifs_super_ops = {
519 .statfs = cifs_statfs,
520 .alloc_inode = cifs_alloc_inode,
521 .destroy_inode = cifs_destroy_inode,
522 .drop_inode = cifs_drop_inode,
523 .evict_inode = cifs_evict_inode,
524 /* .delete_inode = cifs_delete_inode, */ /* Do not need above
525 function unless later we add lazy close of inodes or unless the
526 kernel forgets to call us with the same number of releases (closes)
527 as opens */
528 .show_options = cifs_show_options,
529 .umount_begin = cifs_umount_begin,
530 .remount_fs = cifs_remount,
531 #ifdef CONFIG_CIFS_STATS2
532 .show_stats = cifs_show_stats,
533 #endif
534 };
535
536 /*
537 * Get root dentry from superblock according to prefix path mount option.
538 * Return dentry with refcount + 1 on success and NULL otherwise.
539 */
540 static struct dentry *
541 cifs_get_root(struct smb_vol *vol, struct super_block *sb)
542 {
543 struct dentry *dentry;
544 struct cifs_sb_info *cifs_sb = CIFS_SB(sb);
545 char *full_path = NULL;
546 char *s, *p;
547 char sep;
548
549 full_path = cifs_build_path_to_root(vol, cifs_sb,
550 cifs_sb_master_tcon(cifs_sb));
551 if (full_path == NULL)
552 return ERR_PTR(-ENOMEM);
553
554 cFYI(1, "Get root dentry for %s", full_path);
555
556 sep = CIFS_DIR_SEP(cifs_sb);
557 dentry = dget(sb->s_root);
558 p = s = full_path;
559
560 do {
561 struct inode *dir = dentry->d_inode;
562 struct dentry *child;
563
564 if (!dir) {
565 dput(dentry);
566 dentry = ERR_PTR(-ENOENT);
567 break;
568 }
569
570 /* skip separators */
571 while (*s == sep)
572 s++;
573 if (!*s)
574 break;
575 p = s++;
576 /* next separator */
577 while (*s && *s != sep)
578 s++;
579
580 mutex_lock(&dir->i_mutex);
581 child = lookup_one_len(p, dentry, s - p);
582 mutex_unlock(&dir->i_mutex);
583 dput(dentry);
584 dentry = child;
585 } while (!IS_ERR(dentry));
586 kfree(full_path);
587 return dentry;
588 }
589
590 static int cifs_set_super(struct super_block *sb, void *data)
591 {
592 struct cifs_mnt_data *mnt_data = data;
593 sb->s_fs_info = mnt_data->cifs_sb;
594 return set_anon_super(sb, NULL);
595 }
596
597 static struct dentry *
598 cifs_do_mount(struct file_system_type *fs_type,
599 int flags, const char *dev_name, void *data)
600 {
601 int rc;
602 struct super_block *sb;
603 struct cifs_sb_info *cifs_sb;
604 struct smb_vol *volume_info;
605 struct cifs_mnt_data mnt_data;
606 struct dentry *root;
607
608 cFYI(1, "Devname: %s flags: %d ", dev_name, flags);
609
610 volume_info = cifs_get_volume_info((char *)data, dev_name);
611 if (IS_ERR(volume_info))
612 return ERR_CAST(volume_info);
613
614 cifs_sb = kzalloc(sizeof(struct cifs_sb_info), GFP_KERNEL);
615 if (cifs_sb == NULL) {
616 root = ERR_PTR(-ENOMEM);
617 goto out_nls;
618 }
619
620 cifs_sb->mountdata = kstrndup(data, PAGE_SIZE, GFP_KERNEL);
621 if (cifs_sb->mountdata == NULL) {
622 root = ERR_PTR(-ENOMEM);
623 goto out_cifs_sb;
624 }
625
626 cifs_setup_cifs_sb(volume_info, cifs_sb);
627
628 rc = cifs_mount(cifs_sb, volume_info);
629 if (rc) {
630 if (!(flags & MS_SILENT))
631 cERROR(1, "cifs_mount failed w/return code = %d", rc);
632 root = ERR_PTR(rc);
633 goto out_mountdata;
634 }
635
636 mnt_data.vol = volume_info;
637 mnt_data.cifs_sb = cifs_sb;
638 mnt_data.flags = flags;
639
640 sb = sget(fs_type, cifs_match_super, cifs_set_super, &mnt_data);
641 if (IS_ERR(sb)) {
642 root = ERR_CAST(sb);
643 cifs_umount(cifs_sb);
644 goto out;
645 }
646
647 if (sb->s_root) {
648 cFYI(1, "Use existing superblock");
649 cifs_umount(cifs_sb);
650 } else {
651 sb->s_flags = flags;
652 /* BB should we make this contingent on mount parm? */
653 sb->s_flags |= MS_NODIRATIME | MS_NOATIME;
654
655 rc = cifs_read_super(sb);
656 if (rc) {
657 root = ERR_PTR(rc);
658 goto out_super;
659 }
660
661 sb->s_flags |= MS_ACTIVE;
662 }
663
664 root = cifs_get_root(volume_info, sb);
665 if (IS_ERR(root))
666 goto out_super;
667
668 cFYI(1, "dentry root is: %p", root);
669 goto out;
670
671 out_super:
672 deactivate_locked_super(sb);
673 out:
674 cifs_cleanup_volume_info(volume_info);
675 return root;
676
677 out_mountdata:
678 kfree(cifs_sb->mountdata);
679 out_cifs_sb:
680 kfree(cifs_sb);
681 out_nls:
682 unload_nls(volume_info->local_nls);
683 goto out;
684 }
685
686 static ssize_t cifs_file_aio_write(struct kiocb *iocb, const struct iovec *iov,
687 unsigned long nr_segs, loff_t pos)
688 {
689 struct inode *inode = iocb->ki_filp->f_path.dentry->d_inode;
690 ssize_t written;
691 int rc;
692
693 written = generic_file_aio_write(iocb, iov, nr_segs, pos);
694
695 if (CIFS_I(inode)->clientCanCacheAll)
696 return written;
697
698 rc = filemap_fdatawrite(inode->i_mapping);
699 if (rc)
700 cFYI(1, "cifs_file_aio_write: %d rc on %p inode", rc, inode);
701
702 return written;
703 }
704
705 static loff_t cifs_llseek(struct file *file, loff_t offset, int origin)
706 {
707 /*
708 * origin == SEEK_END || SEEK_DATA || SEEK_HOLE => we must revalidate
709 * the cached file length
710 */
711 if (origin != SEEK_SET && origin != SEEK_CUR) {
712 int rc;
713 struct inode *inode = file->f_path.dentry->d_inode;
714
715 /*
716 * We need to be sure that all dirty pages are written and the
717 * server has the newest file length.
718 */
719 if (!CIFS_I(inode)->clientCanCacheRead && inode->i_mapping &&
720 inode->i_mapping->nrpages != 0) {
721 rc = filemap_fdatawait(inode->i_mapping);
722 if (rc) {
723 mapping_set_error(inode->i_mapping, rc);
724 return rc;
725 }
726 }
727 /*
728 * Some applications poll for the file length in this strange
729 * way so we must seek to end on non-oplocked files by
730 * setting the revalidate time to zero.
731 */
732 CIFS_I(inode)->time = 0;
733
734 rc = cifs_revalidate_file_attr(file);
735 if (rc < 0)
736 return (loff_t)rc;
737 }
738 return generic_file_llseek(file, offset, origin);
739 }
740
741 static int cifs_setlease(struct file *file, long arg, struct file_lock **lease)
742 {
743 /* note that this is called by vfs setlease with lock_flocks held
744 to protect *lease from going away */
745 struct inode *inode = file->f_path.dentry->d_inode;
746 struct cifsFileInfo *cfile = file->private_data;
747
748 if (!(S_ISREG(inode->i_mode)))
749 return -EINVAL;
750
751 /* check if file is oplocked */
752 if (((arg == F_RDLCK) &&
753 (CIFS_I(inode)->clientCanCacheRead)) ||
754 ((arg == F_WRLCK) &&
755 (CIFS_I(inode)->clientCanCacheAll)))
756 return generic_setlease(file, arg, lease);
757 else if (tlink_tcon(cfile->tlink)->local_lease &&
758 !CIFS_I(inode)->clientCanCacheRead)
759 /* If the server claims to support oplock on this
760 file, then we still need to check oplock even
761 if the local_lease mount option is set, but there
762 are servers which do not support oplock for which
763 this mount option may be useful if the user
764 knows that the file won't be changed on the server
765 by anyone else */
766 return generic_setlease(file, arg, lease);
767 else
768 return -EAGAIN;
769 }
770
771 struct file_system_type cifs_fs_type = {
772 .owner = THIS_MODULE,
773 .name = "cifs",
774 .mount = cifs_do_mount,
775 .kill_sb = cifs_kill_sb,
776 /* .fs_flags */
777 };
778 const struct inode_operations cifs_dir_inode_ops = {
779 .create = cifs_create,
780 .atomic_open = cifs_atomic_open,
781 .lookup = cifs_lookup,
782 .getattr = cifs_getattr,
783 .unlink = cifs_unlink,
784 .link = cifs_hardlink,
785 .mkdir = cifs_mkdir,
786 .rmdir = cifs_rmdir,
787 .rename = cifs_rename,
788 .permission = cifs_permission,
789 /* revalidate:cifs_revalidate, */
790 .setattr = cifs_setattr,
791 .symlink = cifs_symlink,
792 .mknod = cifs_mknod,
793 #ifdef CONFIG_CIFS_XATTR
794 .setxattr = cifs_setxattr,
795 .getxattr = cifs_getxattr,
796 .listxattr = cifs_listxattr,
797 .removexattr = cifs_removexattr,
798 #endif
799 };
800
801 const struct inode_operations cifs_file_inode_ops = {
802 /* revalidate:cifs_revalidate, */
803 .setattr = cifs_setattr,
804 .getattr = cifs_getattr, /* do we need this anymore? */
805 .rename = cifs_rename,
806 .permission = cifs_permission,
807 #ifdef CONFIG_CIFS_XATTR
808 .setxattr = cifs_setxattr,
809 .getxattr = cifs_getxattr,
810 .listxattr = cifs_listxattr,
811 .removexattr = cifs_removexattr,
812 #endif
813 };
814
815 const struct inode_operations cifs_symlink_inode_ops = {
816 .readlink = generic_readlink,
817 .follow_link = cifs_follow_link,
818 .put_link = cifs_put_link,
819 .permission = cifs_permission,
820 /* BB add the following two eventually */
821 /* revalidate: cifs_revalidate,
822 setattr: cifs_notify_change, *//* BB do we need notify change */
823 #ifdef CONFIG_CIFS_XATTR
824 .setxattr = cifs_setxattr,
825 .getxattr = cifs_getxattr,
826 .listxattr = cifs_listxattr,
827 .removexattr = cifs_removexattr,
828 #endif
829 };
830
831 const struct file_operations cifs_file_ops = {
832 .read = do_sync_read,
833 .write = do_sync_write,
834 .aio_read = generic_file_aio_read,
835 .aio_write = cifs_file_aio_write,
836 .open = cifs_open,
837 .release = cifs_close,
838 .lock = cifs_lock,
839 .fsync = cifs_fsync,
840 .flush = cifs_flush,
841 .mmap = cifs_file_mmap,
842 .splice_read = generic_file_splice_read,
843 .llseek = cifs_llseek,
844 #ifdef CONFIG_CIFS_POSIX
845 .unlocked_ioctl = cifs_ioctl,
846 #endif /* CONFIG_CIFS_POSIX */
847 .setlease = cifs_setlease,
848 };
849
850 const struct file_operations cifs_file_strict_ops = {
851 .read = do_sync_read,
852 .write = do_sync_write,
853 .aio_read = cifs_strict_readv,
854 .aio_write = cifs_strict_writev,
855 .open = cifs_open,
856 .release = cifs_close,
857 .lock = cifs_lock,
858 .fsync = cifs_strict_fsync,
859 .flush = cifs_flush,
860 .mmap = cifs_file_strict_mmap,
861 .splice_read = generic_file_splice_read,
862 .llseek = cifs_llseek,
863 #ifdef CONFIG_CIFS_POSIX
864 .unlocked_ioctl = cifs_ioctl,
865 #endif /* CONFIG_CIFS_POSIX */
866 .setlease = cifs_setlease,
867 };
868
869 const struct file_operations cifs_file_direct_ops = {
870 /* BB reevaluate whether they can be done with directio, no cache */
871 .read = do_sync_read,
872 .write = do_sync_write,
873 .aio_read = cifs_user_readv,
874 .aio_write = cifs_user_writev,
875 .open = cifs_open,
876 .release = cifs_close,
877 .lock = cifs_lock,
878 .fsync = cifs_fsync,
879 .flush = cifs_flush,
880 .mmap = cifs_file_mmap,
881 .splice_read = generic_file_splice_read,
882 #ifdef CONFIG_CIFS_POSIX
883 .unlocked_ioctl = cifs_ioctl,
884 #endif /* CONFIG_CIFS_POSIX */
885 .llseek = cifs_llseek,
886 .setlease = cifs_setlease,
887 };
888
889 const struct file_operations cifs_file_nobrl_ops = {
890 .read = do_sync_read,
891 .write = do_sync_write,
892 .aio_read = generic_file_aio_read,
893 .aio_write = cifs_file_aio_write,
894 .open = cifs_open,
895 .release = cifs_close,
896 .fsync = cifs_fsync,
897 .flush = cifs_flush,
898 .mmap = cifs_file_mmap,
899 .splice_read = generic_file_splice_read,
900 .llseek = cifs_llseek,
901 #ifdef CONFIG_CIFS_POSIX
902 .unlocked_ioctl = cifs_ioctl,
903 #endif /* CONFIG_CIFS_POSIX */
904 .setlease = cifs_setlease,
905 };
906
907 const struct file_operations cifs_file_strict_nobrl_ops = {
908 .read = do_sync_read,
909 .write = do_sync_write,
910 .aio_read = cifs_strict_readv,
911 .aio_write = cifs_strict_writev,
912 .open = cifs_open,
913 .release = cifs_close,
914 .fsync = cifs_strict_fsync,
915 .flush = cifs_flush,
916 .mmap = cifs_file_strict_mmap,
917 .splice_read = generic_file_splice_read,
918 .llseek = cifs_llseek,
919 #ifdef CONFIG_CIFS_POSIX
920 .unlocked_ioctl = cifs_ioctl,
921 #endif /* CONFIG_CIFS_POSIX */
922 .setlease = cifs_setlease,
923 };
924
925 const struct file_operations cifs_file_direct_nobrl_ops = {
926 /* BB reevaluate whether they can be done with directio, no cache */
927 .read = do_sync_read,
928 .write = do_sync_write,
929 .aio_read = cifs_user_readv,
930 .aio_write = cifs_user_writev,
931 .open = cifs_open,
932 .release = cifs_close,
933 .fsync = cifs_fsync,
934 .flush = cifs_flush,
935 .mmap = cifs_file_mmap,
936 .splice_read = generic_file_splice_read,
937 #ifdef CONFIG_CIFS_POSIX
938 .unlocked_ioctl = cifs_ioctl,
939 #endif /* CONFIG_CIFS_POSIX */
940 .llseek = cifs_llseek,
941 .setlease = cifs_setlease,
942 };
943
944 const struct file_operations cifs_dir_ops = {
945 .readdir = cifs_readdir,
946 .release = cifs_closedir,
947 .read = generic_read_dir,
948 .unlocked_ioctl = cifs_ioctl,
949 .llseek = generic_file_llseek,
950 };
951
952 static void
953 cifs_init_once(void *inode)
954 {
955 struct cifsInodeInfo *cifsi = inode;
956
957 inode_init_once(&cifsi->vfs_inode);
958 mutex_init(&cifsi->lock_mutex);
959 }
960
961 static int
962 cifs_init_inodecache(void)
963 {
964 cifs_inode_cachep = kmem_cache_create("cifs_inode_cache",
965 sizeof(struct cifsInodeInfo),
966 0, (SLAB_RECLAIM_ACCOUNT|
967 SLAB_MEM_SPREAD),
968 cifs_init_once);
969 if (cifs_inode_cachep == NULL)
970 return -ENOMEM;
971
972 return 0;
973 }
974
975 static void
976 cifs_destroy_inodecache(void)
977 {
978 kmem_cache_destroy(cifs_inode_cachep);
979 }
980
981 static int
982 cifs_init_request_bufs(void)
983 {
984 if (CIFSMaxBufSize < 8192) {
985 /* Buffer size can not be smaller than 2 * PATH_MAX since maximum
986 Unicode path name has to fit in any SMB/CIFS path based frames */
987 CIFSMaxBufSize = 8192;
988 } else if (CIFSMaxBufSize > 1024*127) {
989 CIFSMaxBufSize = 1024 * 127;
990 } else {
991 CIFSMaxBufSize &= 0x1FE00; /* Round size to even 512 byte mult*/
992 }
993 /* cERROR(1, "CIFSMaxBufSize %d 0x%x",CIFSMaxBufSize,CIFSMaxBufSize); */
994 cifs_req_cachep = kmem_cache_create("cifs_request",
995 CIFSMaxBufSize +
996 MAX_CIFS_HDR_SIZE, 0,
997 SLAB_HWCACHE_ALIGN, NULL);
998 if (cifs_req_cachep == NULL)
999 return -ENOMEM;
1000
1001 if (cifs_min_rcv < 1)
1002 cifs_min_rcv = 1;
1003 else if (cifs_min_rcv > 64) {
1004 cifs_min_rcv = 64;
1005 cERROR(1, "cifs_min_rcv set to maximum (64)");
1006 }
1007
1008 cifs_req_poolp = mempool_create_slab_pool(cifs_min_rcv,
1009 cifs_req_cachep);
1010
1011 if (cifs_req_poolp == NULL) {
1012 kmem_cache_destroy(cifs_req_cachep);
1013 return -ENOMEM;
1014 }
1015 /* MAX_CIFS_SMALL_BUFFER_SIZE bytes is enough for most SMB responses and
1016 almost all handle based requests (but not write response, nor is it
1017 sufficient for path based requests). A smaller size would have
1018 been more efficient (compacting multiple slab items on one 4k page)
1019 for the case in which debug was on, but this larger size allows
1020 more SMBs to use small buffer alloc and is still much more
1021 efficient to alloc 1 per page off the slab compared to 17K (5page)
1022 alloc of large cifs buffers even when page debugging is on */
1023 cifs_sm_req_cachep = kmem_cache_create("cifs_small_rq",
1024 MAX_CIFS_SMALL_BUFFER_SIZE, 0, SLAB_HWCACHE_ALIGN,
1025 NULL);
1026 if (cifs_sm_req_cachep == NULL) {
1027 mempool_destroy(cifs_req_poolp);
1028 kmem_cache_destroy(cifs_req_cachep);
1029 return -ENOMEM;
1030 }
1031
1032 if (cifs_min_small < 2)
1033 cifs_min_small = 2;
1034 else if (cifs_min_small > 256) {
1035 cifs_min_small = 256;
1036 cFYI(1, "cifs_min_small set to maximum (256)");
1037 }
1038
1039 cifs_sm_req_poolp = mempool_create_slab_pool(cifs_min_small,
1040 cifs_sm_req_cachep);
1041
1042 if (cifs_sm_req_poolp == NULL) {
1043 mempool_destroy(cifs_req_poolp);
1044 kmem_cache_destroy(cifs_req_cachep);
1045 kmem_cache_destroy(cifs_sm_req_cachep);
1046 return -ENOMEM;
1047 }
1048
1049 return 0;
1050 }
1051
1052 static void
1053 cifs_destroy_request_bufs(void)
1054 {
1055 mempool_destroy(cifs_req_poolp);
1056 kmem_cache_destroy(cifs_req_cachep);
1057 mempool_destroy(cifs_sm_req_poolp);
1058 kmem_cache_destroy(cifs_sm_req_cachep);
1059 }
1060
1061 static int
1062 cifs_init_mids(void)
1063 {
1064 cifs_mid_cachep = kmem_cache_create("cifs_mpx_ids",
1065 sizeof(struct mid_q_entry), 0,
1066 SLAB_HWCACHE_ALIGN, NULL);
1067 if (cifs_mid_cachep == NULL)
1068 return -ENOMEM;
1069
1070 /* 3 is a reasonable minimum number of simultaneous operations */
1071 cifs_mid_poolp = mempool_create_slab_pool(3, cifs_mid_cachep);
1072 if (cifs_mid_poolp == NULL) {
1073 kmem_cache_destroy(cifs_mid_cachep);
1074 return -ENOMEM;
1075 }
1076
1077 return 0;
1078 }
1079
1080 static void
1081 cifs_destroy_mids(void)
1082 {
1083 mempool_destroy(cifs_mid_poolp);
1084 kmem_cache_destroy(cifs_mid_cachep);
1085 }
1086
1087 static int __init
1088 init_cifs(void)
1089 {
1090 int rc = 0;
1091 cifs_proc_init();
1092 INIT_LIST_HEAD(&cifs_tcp_ses_list);
1093 #ifdef CONFIG_CIFS_DNOTIFY_EXPERIMENTAL /* unused temporarily */
1094 INIT_LIST_HEAD(&GlobalDnotifyReqList);
1095 INIT_LIST_HEAD(&GlobalDnotifyRsp_Q);
1096 #endif /* was needed for dnotify, and will be needed for inotify when VFS fix */
1097 /*
1098 * Initialize Global counters
1099 */
1100 atomic_set(&sesInfoAllocCount, 0);
1101 atomic_set(&tconInfoAllocCount, 0);
1102 atomic_set(&tcpSesAllocCount, 0);
1103 atomic_set(&tcpSesReconnectCount, 0);
1104 atomic_set(&tconInfoReconnectCount, 0);
1105
1106 atomic_set(&bufAllocCount, 0);
1107 atomic_set(&smBufAllocCount, 0);
1108 #ifdef CONFIG_CIFS_STATS2
1109 atomic_set(&totBufAllocCount, 0);
1110 atomic_set(&totSmBufAllocCount, 0);
1111 #endif /* CONFIG_CIFS_STATS2 */
1112
1113 atomic_set(&midCount, 0);
1114 GlobalCurrentXid = 0;
1115 GlobalTotalActiveXid = 0;
1116 GlobalMaxActiveXid = 0;
1117 spin_lock_init(&cifs_tcp_ses_lock);
1118 spin_lock_init(&cifs_file_list_lock);
1119 spin_lock_init(&GlobalMid_Lock);
1120
1121 if (cifs_max_pending < 2) {
1122 cifs_max_pending = 2;
1123 cFYI(1, "cifs_max_pending set to min of 2");
1124 } else if (cifs_max_pending > CIFS_MAX_REQ) {
1125 cifs_max_pending = CIFS_MAX_REQ;
1126 cFYI(1, "cifs_max_pending set to max of %u", CIFS_MAX_REQ);
1127 }
1128
1129 cifsiod_wq = alloc_workqueue("cifsiod", WQ_FREEZABLE|WQ_MEM_RECLAIM, 0);
1130 if (!cifsiod_wq) {
1131 rc = -ENOMEM;
1132 goto out_clean_proc;
1133 }
1134
1135 rc = cifs_fscache_register();
1136 if (rc)
1137 goto out_destroy_wq;
1138
1139 rc = cifs_init_inodecache();
1140 if (rc)
1141 goto out_unreg_fscache;
1142
1143 rc = cifs_init_mids();
1144 if (rc)
1145 goto out_destroy_inodecache;
1146
1147 rc = cifs_init_request_bufs();
1148 if (rc)
1149 goto out_destroy_mids;
1150
1151 #ifdef CONFIG_CIFS_UPCALL
1152 rc = register_key_type(&cifs_spnego_key_type);
1153 if (rc)
1154 goto out_destroy_request_bufs;
1155 #endif /* CONFIG_CIFS_UPCALL */
1156
1157 #ifdef CONFIG_CIFS_ACL
1158 rc = init_cifs_idmap();
1159 if (rc)
1160 goto out_register_key_type;
1161 #endif /* CONFIG_CIFS_ACL */
1162
1163 rc = register_filesystem(&cifs_fs_type);
1164 if (rc)
1165 goto out_init_cifs_idmap;
1166
1167 return 0;
1168
1169 out_init_cifs_idmap:
1170 #ifdef CONFIG_CIFS_ACL
1171 exit_cifs_idmap();
1172 out_register_key_type:
1173 #endif
1174 #ifdef CONFIG_CIFS_UPCALL
1175 unregister_key_type(&cifs_spnego_key_type);
1176 out_destroy_request_bufs:
1177 #endif
1178 cifs_destroy_request_bufs();
1179 out_destroy_mids:
1180 cifs_destroy_mids();
1181 out_destroy_inodecache:
1182 cifs_destroy_inodecache();
1183 out_unreg_fscache:
1184 cifs_fscache_unregister();
1185 out_destroy_wq:
1186 destroy_workqueue(cifsiod_wq);
1187 out_clean_proc:
1188 cifs_proc_clean();
1189 return rc;
1190 }
1191
1192 static void __exit
1193 exit_cifs(void)
1194 {
1195 cFYI(DBG2, "exit_cifs");
1196 unregister_filesystem(&cifs_fs_type);
1197 cifs_dfs_release_automount_timer();
1198 #ifdef CONFIG_CIFS_ACL
1199 cifs_destroy_idmaptrees();
1200 exit_cifs_idmap();
1201 #endif
1202 #ifdef CONFIG_CIFS_UPCALL
1203 unregister_key_type(&cifs_spnego_key_type);
1204 #endif
1205 cifs_destroy_request_bufs();
1206 cifs_destroy_mids();
1207 cifs_destroy_inodecache();
1208 cifs_fscache_unregister();
1209 destroy_workqueue(cifsiod_wq);
1210 cifs_proc_clean();
1211 }
1212
1213 MODULE_AUTHOR("Steve French <sfrench@us.ibm.com>");
1214 MODULE_LICENSE("GPL"); /* combination of LGPL + GPL source behaves as GPL */
1215 MODULE_DESCRIPTION
1216 ("VFS to access servers complying with the SNIA CIFS Specification "
1217 "e.g. Samba and Windows");
1218 MODULE_VERSION(CIFS_VERSION);
1219 module_init(init_cifs)
1220 module_exit(exit_cifs)
This page took 0.056085 seconds and 5 git commands to generate.