4 * vfs operations that deal with files
6 * Copyright (C) International Business Machines Corp., 2002,2010
7 * Author(s): Steve French (sfrench@us.ibm.com)
8 * Jeremy Allison (jra@samba.org)
10 * This library is free software; you can redistribute it and/or modify
11 * it under the terms of the GNU Lesser General Public License as published
12 * by the Free Software Foundation; either version 2.1 of the License, or
13 * (at your option) any later version.
15 * This library is distributed in the hope that it will be useful,
16 * but WITHOUT ANY WARRANTY; without even the implied warranty of
17 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See
18 * the GNU Lesser General Public License for more details.
20 * You should have received a copy of the GNU Lesser General Public License
21 * along with this library; if not, write to the Free Software
22 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
25 #include <linux/backing-dev.h>
26 #include <linux/stat.h>
27 #include <linux/fcntl.h>
28 #include <linux/pagemap.h>
29 #include <linux/pagevec.h>
30 #include <linux/writeback.h>
31 #include <linux/task_io_accounting_ops.h>
32 #include <linux/delay.h>
33 #include <linux/mount.h>
34 #include <linux/slab.h>
35 #include <linux/swap.h>
36 #include <asm/div64.h>
40 #include "cifsproto.h"
41 #include "cifs_unicode.h"
42 #include "cifs_debug.h"
43 #include "cifs_fs_sb.h"
47 static inline int cifs_convert_flags(unsigned int flags
)
49 if ((flags
& O_ACCMODE
) == O_RDONLY
)
51 else if ((flags
& O_ACCMODE
) == O_WRONLY
)
53 else if ((flags
& O_ACCMODE
) == O_RDWR
) {
54 /* GENERIC_ALL is too much permission to request
55 can cause unnecessary access denied on create */
56 /* return GENERIC_ALL; */
57 return (GENERIC_READ
| GENERIC_WRITE
);
60 return (READ_CONTROL
| FILE_WRITE_ATTRIBUTES
| FILE_READ_ATTRIBUTES
|
61 FILE_WRITE_EA
| FILE_APPEND_DATA
| FILE_WRITE_DATA
|
65 static u32
cifs_posix_convert_flags(unsigned int flags
)
69 if ((flags
& O_ACCMODE
) == O_RDONLY
)
70 posix_flags
= SMB_O_RDONLY
;
71 else if ((flags
& O_ACCMODE
) == O_WRONLY
)
72 posix_flags
= SMB_O_WRONLY
;
73 else if ((flags
& O_ACCMODE
) == O_RDWR
)
74 posix_flags
= SMB_O_RDWR
;
76 if (flags
& O_CREAT
) {
77 posix_flags
|= SMB_O_CREAT
;
79 posix_flags
|= SMB_O_EXCL
;
80 } else if (flags
& O_EXCL
)
81 cifs_dbg(FYI
, "Application %s pid %d has incorrectly set O_EXCL flag but not O_CREAT on file open. Ignoring O_EXCL\n",
82 current
->comm
, current
->tgid
);
85 posix_flags
|= SMB_O_TRUNC
;
86 /* be safe and imply O_SYNC for O_DSYNC */
88 posix_flags
|= SMB_O_SYNC
;
89 if (flags
& O_DIRECTORY
)
90 posix_flags
|= SMB_O_DIRECTORY
;
91 if (flags
& O_NOFOLLOW
)
92 posix_flags
|= SMB_O_NOFOLLOW
;
94 posix_flags
|= SMB_O_DIRECT
;
99 static inline int cifs_get_disposition(unsigned int flags
)
101 if ((flags
& (O_CREAT
| O_EXCL
)) == (O_CREAT
| O_EXCL
))
103 else if ((flags
& (O_CREAT
| O_TRUNC
)) == (O_CREAT
| O_TRUNC
))
104 return FILE_OVERWRITE_IF
;
105 else if ((flags
& O_CREAT
) == O_CREAT
)
107 else if ((flags
& O_TRUNC
) == O_TRUNC
)
108 return FILE_OVERWRITE
;
113 int cifs_posix_open(char *full_path
, struct inode
**pinode
,
114 struct super_block
*sb
, int mode
, unsigned int f_flags
,
115 __u32
*poplock
, __u16
*pnetfid
, unsigned int xid
)
118 FILE_UNIX_BASIC_INFO
*presp_data
;
119 __u32 posix_flags
= 0;
120 struct cifs_sb_info
*cifs_sb
= CIFS_SB(sb
);
121 struct cifs_fattr fattr
;
122 struct tcon_link
*tlink
;
123 struct cifs_tcon
*tcon
;
125 cifs_dbg(FYI
, "posix open %s\n", full_path
);
127 presp_data
= kzalloc(sizeof(FILE_UNIX_BASIC_INFO
), GFP_KERNEL
);
128 if (presp_data
== NULL
)
131 tlink
= cifs_sb_tlink(cifs_sb
);
137 tcon
= tlink_tcon(tlink
);
138 mode
&= ~current_umask();
140 posix_flags
= cifs_posix_convert_flags(f_flags
);
141 rc
= CIFSPOSIXCreate(xid
, tcon
, posix_flags
, mode
, pnetfid
, presp_data
,
142 poplock
, full_path
, cifs_sb
->local_nls
,
143 cifs_remap(cifs_sb
));
144 cifs_put_tlink(tlink
);
149 if (presp_data
->Type
== cpu_to_le32(-1))
150 goto posix_open_ret
; /* open ok, caller does qpathinfo */
153 goto posix_open_ret
; /* caller does not need info */
155 cifs_unix_basic_to_fattr(&fattr
, presp_data
, cifs_sb
);
157 /* get new inode and set it up */
158 if (*pinode
== NULL
) {
159 cifs_fill_uniqueid(sb
, &fattr
);
160 *pinode
= cifs_iget(sb
, &fattr
);
166 cifs_fattr_to_inode(*pinode
, &fattr
);
175 cifs_nt_open(char *full_path
, struct inode
*inode
, struct cifs_sb_info
*cifs_sb
,
176 struct cifs_tcon
*tcon
, unsigned int f_flags
, __u32
*oplock
,
177 struct cifs_fid
*fid
, unsigned int xid
)
182 int create_options
= CREATE_NOT_DIR
;
184 struct TCP_Server_Info
*server
= tcon
->ses
->server
;
185 struct cifs_open_parms oparms
;
187 if (!server
->ops
->open
)
190 desired_access
= cifs_convert_flags(f_flags
);
192 /*********************************************************************
193 * open flag mapping table:
195 * POSIX Flag CIFS Disposition
196 * ---------- ----------------
197 * O_CREAT FILE_OPEN_IF
198 * O_CREAT | O_EXCL FILE_CREATE
199 * O_CREAT | O_TRUNC FILE_OVERWRITE_IF
200 * O_TRUNC FILE_OVERWRITE
201 * none of the above FILE_OPEN
203 * Note that there is not a direct match between disposition
204 * FILE_SUPERSEDE (ie create whether or not file exists although
205 * O_CREAT | O_TRUNC is similar but truncates the existing
206 * file rather than creating a new file as FILE_SUPERSEDE does
207 * (which uses the attributes / metadata passed in on open call)
209 *? O_SYNC is a reasonable match to CIFS writethrough flag
210 *? and the read write flags match reasonably. O_LARGEFILE
211 *? is irrelevant because largefile support is always used
212 *? by this client. Flags O_APPEND, O_DIRECT, O_DIRECTORY,
213 * O_FASYNC, O_NOFOLLOW, O_NONBLOCK need further investigation
214 *********************************************************************/
216 disposition
= cifs_get_disposition(f_flags
);
218 /* BB pass O_SYNC flag through on file attributes .. BB */
220 buf
= kmalloc(sizeof(FILE_ALL_INFO
), GFP_KERNEL
);
224 if (backup_cred(cifs_sb
))
225 create_options
|= CREATE_OPEN_BACKUP_INTENT
;
228 oparms
.cifs_sb
= cifs_sb
;
229 oparms
.desired_access
= desired_access
;
230 oparms
.create_options
= create_options
;
231 oparms
.disposition
= disposition
;
232 oparms
.path
= full_path
;
234 oparms
.reconnect
= false;
236 rc
= server
->ops
->open(xid
, &oparms
, oplock
, buf
);
242 rc
= cifs_get_inode_info_unix(&inode
, full_path
, inode
->i_sb
,
245 rc
= cifs_get_inode_info(&inode
, full_path
, buf
, inode
->i_sb
,
254 cifs_has_mand_locks(struct cifsInodeInfo
*cinode
)
256 struct cifs_fid_locks
*cur
;
257 bool has_locks
= false;
259 down_read(&cinode
->lock_sem
);
260 list_for_each_entry(cur
, &cinode
->llist
, llist
) {
261 if (!list_empty(&cur
->locks
)) {
266 up_read(&cinode
->lock_sem
);
270 struct cifsFileInfo
*
271 cifs_new_fileinfo(struct cifs_fid
*fid
, struct file
*file
,
272 struct tcon_link
*tlink
, __u32 oplock
)
274 struct dentry
*dentry
= file_dentry(file
);
275 struct inode
*inode
= d_inode(dentry
);
276 struct cifsInodeInfo
*cinode
= CIFS_I(inode
);
277 struct cifsFileInfo
*cfile
;
278 struct cifs_fid_locks
*fdlocks
;
279 struct cifs_tcon
*tcon
= tlink_tcon(tlink
);
280 struct TCP_Server_Info
*server
= tcon
->ses
->server
;
282 cfile
= kzalloc(sizeof(struct cifsFileInfo
), GFP_KERNEL
);
286 fdlocks
= kzalloc(sizeof(struct cifs_fid_locks
), GFP_KERNEL
);
292 INIT_LIST_HEAD(&fdlocks
->locks
);
293 fdlocks
->cfile
= cfile
;
294 cfile
->llist
= fdlocks
;
295 down_write(&cinode
->lock_sem
);
296 list_add(&fdlocks
->llist
, &cinode
->llist
);
297 up_write(&cinode
->lock_sem
);
300 cfile
->pid
= current
->tgid
;
301 cfile
->uid
= current_fsuid();
302 cfile
->dentry
= dget(dentry
);
303 cfile
->f_flags
= file
->f_flags
;
304 cfile
->invalidHandle
= false;
305 cfile
->tlink
= cifs_get_tlink(tlink
);
306 INIT_WORK(&cfile
->oplock_break
, cifs_oplock_break
);
307 mutex_init(&cfile
->fh_mutex
);
308 spin_lock_init(&cfile
->file_info_lock
);
310 cifs_sb_active(inode
->i_sb
);
313 * If the server returned a read oplock and we have mandatory brlocks,
314 * set oplock level to None.
316 if (server
->ops
->is_read_op(oplock
) && cifs_has_mand_locks(cinode
)) {
317 cifs_dbg(FYI
, "Reset oplock val from read to None due to mand locks\n");
321 spin_lock(&tcon
->open_file_lock
);
322 if (fid
->pending_open
->oplock
!= CIFS_OPLOCK_NO_CHANGE
&& oplock
)
323 oplock
= fid
->pending_open
->oplock
;
324 list_del(&fid
->pending_open
->olist
);
326 fid
->purge_cache
= false;
327 server
->ops
->set_fid(cfile
, fid
, oplock
);
329 list_add(&cfile
->tlist
, &tcon
->openFileList
);
331 /* if readable file instance put first in list*/
332 if (file
->f_mode
& FMODE_READ
)
333 list_add(&cfile
->flist
, &cinode
->openFileList
);
335 list_add_tail(&cfile
->flist
, &cinode
->openFileList
);
336 spin_unlock(&tcon
->open_file_lock
);
338 if (fid
->purge_cache
)
339 cifs_zap_mapping(inode
);
341 file
->private_data
= cfile
;
345 struct cifsFileInfo
*
346 cifsFileInfo_get(struct cifsFileInfo
*cifs_file
)
348 spin_lock(&cifs_file
->file_info_lock
);
349 cifsFileInfo_get_locked(cifs_file
);
350 spin_unlock(&cifs_file
->file_info_lock
);
355 * Release a reference on the file private data. This may involve closing
356 * the filehandle out on the server. Must be called without holding
357 * tcon->open_file_lock and cifs_file->file_info_lock.
359 void cifsFileInfo_put(struct cifsFileInfo
*cifs_file
)
361 struct inode
*inode
= d_inode(cifs_file
->dentry
);
362 struct cifs_tcon
*tcon
= tlink_tcon(cifs_file
->tlink
);
363 struct TCP_Server_Info
*server
= tcon
->ses
->server
;
364 struct cifsInodeInfo
*cifsi
= CIFS_I(inode
);
365 struct super_block
*sb
= inode
->i_sb
;
366 struct cifs_sb_info
*cifs_sb
= CIFS_SB(sb
);
367 struct cifsLockInfo
*li
, *tmp
;
369 struct cifs_pending_open open
;
370 bool oplock_break_cancelled
;
372 spin_lock(&tcon
->open_file_lock
);
374 spin_lock(&cifs_file
->file_info_lock
);
375 if (--cifs_file
->count
> 0) {
376 spin_unlock(&cifs_file
->file_info_lock
);
377 spin_unlock(&tcon
->open_file_lock
);
380 spin_unlock(&cifs_file
->file_info_lock
);
382 if (server
->ops
->get_lease_key
)
383 server
->ops
->get_lease_key(inode
, &fid
);
385 /* store open in pending opens to make sure we don't miss lease break */
386 cifs_add_pending_open_locked(&fid
, cifs_file
->tlink
, &open
);
388 /* remove it from the lists */
389 list_del(&cifs_file
->flist
);
390 list_del(&cifs_file
->tlist
);
392 if (list_empty(&cifsi
->openFileList
)) {
393 cifs_dbg(FYI
, "closing last open instance for inode %p\n",
394 d_inode(cifs_file
->dentry
));
396 * In strict cache mode we need invalidate mapping on the last
397 * close because it may cause a error when we open this file
398 * again and get at least level II oplock.
400 if (cifs_sb
->mnt_cifs_flags
& CIFS_MOUNT_STRICT_IO
)
401 set_bit(CIFS_INO_INVALID_MAPPING
, &cifsi
->flags
);
402 cifs_set_oplock_level(cifsi
, 0);
405 spin_unlock(&tcon
->open_file_lock
);
407 oplock_break_cancelled
= cancel_work_sync(&cifs_file
->oplock_break
);
409 if (!tcon
->need_reconnect
&& !cifs_file
->invalidHandle
) {
410 struct TCP_Server_Info
*server
= tcon
->ses
->server
;
414 if (server
->ops
->close
)
415 server
->ops
->close(xid
, tcon
, &cifs_file
->fid
);
419 if (oplock_break_cancelled
)
420 cifs_done_oplock_break(cifsi
);
422 cifs_del_pending_open(&open
);
425 * Delete any outstanding lock records. We'll lose them when the file
428 down_write(&cifsi
->lock_sem
);
429 list_for_each_entry_safe(li
, tmp
, &cifs_file
->llist
->locks
, llist
) {
430 list_del(&li
->llist
);
431 cifs_del_lock_waiters(li
);
434 list_del(&cifs_file
->llist
->llist
);
435 kfree(cifs_file
->llist
);
436 up_write(&cifsi
->lock_sem
);
438 cifs_put_tlink(cifs_file
->tlink
);
439 dput(cifs_file
->dentry
);
440 cifs_sb_deactive(sb
);
444 int cifs_open(struct inode
*inode
, struct file
*file
)
450 struct cifs_sb_info
*cifs_sb
;
451 struct TCP_Server_Info
*server
;
452 struct cifs_tcon
*tcon
;
453 struct tcon_link
*tlink
;
454 struct cifsFileInfo
*cfile
= NULL
;
455 char *full_path
= NULL
;
456 bool posix_open_ok
= false;
458 struct cifs_pending_open open
;
462 cifs_sb
= CIFS_SB(inode
->i_sb
);
463 tlink
= cifs_sb_tlink(cifs_sb
);
466 return PTR_ERR(tlink
);
468 tcon
= tlink_tcon(tlink
);
469 server
= tcon
->ses
->server
;
471 full_path
= build_path_from_dentry(file_dentry(file
));
472 if (full_path
== NULL
) {
477 cifs_dbg(FYI
, "inode = 0x%p file flags are 0x%x for %s\n",
478 inode
, file
->f_flags
, full_path
);
480 if (file
->f_flags
& O_DIRECT
&&
481 cifs_sb
->mnt_cifs_flags
& CIFS_MOUNT_STRICT_IO
) {
482 if (cifs_sb
->mnt_cifs_flags
& CIFS_MOUNT_NO_BRL
)
483 file
->f_op
= &cifs_file_direct_nobrl_ops
;
485 file
->f_op
= &cifs_file_direct_ops
;
493 if (!tcon
->broken_posix_open
&& tcon
->unix_ext
&&
494 cap_unix(tcon
->ses
) && (CIFS_UNIX_POSIX_PATH_OPS_CAP
&
495 le64_to_cpu(tcon
->fsUnixInfo
.Capability
))) {
496 /* can not refresh inode info since size could be stale */
497 rc
= cifs_posix_open(full_path
, &inode
, inode
->i_sb
,
498 cifs_sb
->mnt_file_mode
/* ignored */,
499 file
->f_flags
, &oplock
, &fid
.netfid
, xid
);
501 cifs_dbg(FYI
, "posix open succeeded\n");
502 posix_open_ok
= true;
503 } else if ((rc
== -EINVAL
) || (rc
== -EOPNOTSUPP
)) {
504 if (tcon
->ses
->serverNOS
)
505 cifs_dbg(VFS
, "server %s of type %s returned unexpected error on SMB posix open, disabling posix open support. Check if server update available.\n",
506 tcon
->ses
->serverName
,
507 tcon
->ses
->serverNOS
);
508 tcon
->broken_posix_open
= true;
509 } else if ((rc
!= -EIO
) && (rc
!= -EREMOTE
) &&
510 (rc
!= -EOPNOTSUPP
)) /* path not found or net err */
513 * Else fallthrough to retry open the old way on network i/o
518 if (server
->ops
->get_lease_key
)
519 server
->ops
->get_lease_key(inode
, &fid
);
521 cifs_add_pending_open(&fid
, tlink
, &open
);
523 if (!posix_open_ok
) {
524 if (server
->ops
->get_lease_key
)
525 server
->ops
->get_lease_key(inode
, &fid
);
527 rc
= cifs_nt_open(full_path
, inode
, cifs_sb
, tcon
,
528 file
->f_flags
, &oplock
, &fid
, xid
);
530 cifs_del_pending_open(&open
);
535 cfile
= cifs_new_fileinfo(&fid
, file
, tlink
, oplock
);
537 if (server
->ops
->close
)
538 server
->ops
->close(xid
, tcon
, &fid
);
539 cifs_del_pending_open(&open
);
544 cifs_fscache_set_inode_cookie(inode
, file
);
546 if ((oplock
& CIFS_CREATE_ACTION
) && !posix_open_ok
&& tcon
->unix_ext
) {
548 * Time to set mode which we can not set earlier due to
549 * problems creating new read-only files.
551 struct cifs_unix_set_info_args args
= {
552 .mode
= inode
->i_mode
,
553 .uid
= INVALID_UID
, /* no change */
554 .gid
= INVALID_GID
, /* no change */
555 .ctime
= NO_CHANGE_64
,
556 .atime
= NO_CHANGE_64
,
557 .mtime
= NO_CHANGE_64
,
560 CIFSSMBUnixSetFileInfo(xid
, tcon
, &args
, fid
.netfid
,
567 cifs_put_tlink(tlink
);
571 static int cifs_push_posix_locks(struct cifsFileInfo
*cfile
);
574 * Try to reacquire byte range locks that were released when session
575 * to server was lost.
578 cifs_relock_file(struct cifsFileInfo
*cfile
)
580 struct cifs_sb_info
*cifs_sb
= CIFS_SB(cfile
->dentry
->d_sb
);
581 struct cifsInodeInfo
*cinode
= CIFS_I(d_inode(cfile
->dentry
));
582 struct cifs_tcon
*tcon
= tlink_tcon(cfile
->tlink
);
585 down_read(&cinode
->lock_sem
);
586 if (cinode
->can_cache_brlcks
) {
587 /* can cache locks - no need to relock */
588 up_read(&cinode
->lock_sem
);
592 if (cap_unix(tcon
->ses
) &&
593 (CIFS_UNIX_FCNTL_CAP
& le64_to_cpu(tcon
->fsUnixInfo
.Capability
)) &&
594 ((cifs_sb
->mnt_cifs_flags
& CIFS_MOUNT_NOPOSIXBRL
) == 0))
595 rc
= cifs_push_posix_locks(cfile
);
597 rc
= tcon
->ses
->server
->ops
->push_mand_locks(cfile
);
599 up_read(&cinode
->lock_sem
);
604 cifs_reopen_file(struct cifsFileInfo
*cfile
, bool can_flush
)
609 struct cifs_sb_info
*cifs_sb
;
610 struct cifs_tcon
*tcon
;
611 struct TCP_Server_Info
*server
;
612 struct cifsInodeInfo
*cinode
;
614 char *full_path
= NULL
;
616 int disposition
= FILE_OPEN
;
617 int create_options
= CREATE_NOT_DIR
;
618 struct cifs_open_parms oparms
;
621 mutex_lock(&cfile
->fh_mutex
);
622 if (!cfile
->invalidHandle
) {
623 mutex_unlock(&cfile
->fh_mutex
);
629 inode
= d_inode(cfile
->dentry
);
630 cifs_sb
= CIFS_SB(inode
->i_sb
);
631 tcon
= tlink_tcon(cfile
->tlink
);
632 server
= tcon
->ses
->server
;
635 * Can not grab rename sem here because various ops, including those
636 * that already have the rename sem can end up causing writepage to get
637 * called and if the server was down that means we end up here, and we
638 * can never tell if the caller already has the rename_sem.
640 full_path
= build_path_from_dentry(cfile
->dentry
);
641 if (full_path
== NULL
) {
643 mutex_unlock(&cfile
->fh_mutex
);
648 cifs_dbg(FYI
, "inode = 0x%p file flags 0x%x for %s\n",
649 inode
, cfile
->f_flags
, full_path
);
651 if (tcon
->ses
->server
->oplocks
)
656 if (tcon
->unix_ext
&& cap_unix(tcon
->ses
) &&
657 (CIFS_UNIX_POSIX_PATH_OPS_CAP
&
658 le64_to_cpu(tcon
->fsUnixInfo
.Capability
))) {
660 * O_CREAT, O_EXCL and O_TRUNC already had their effect on the
661 * original open. Must mask them off for a reopen.
663 unsigned int oflags
= cfile
->f_flags
&
664 ~(O_CREAT
| O_EXCL
| O_TRUNC
);
666 rc
= cifs_posix_open(full_path
, NULL
, inode
->i_sb
,
667 cifs_sb
->mnt_file_mode
/* ignored */,
668 oflags
, &oplock
, &cfile
->fid
.netfid
, xid
);
670 cifs_dbg(FYI
, "posix reopen succeeded\n");
671 oparms
.reconnect
= true;
675 * fallthrough to retry open the old way on errors, especially
676 * in the reconnect path it is important to retry hard
680 desired_access
= cifs_convert_flags(cfile
->f_flags
);
682 if (backup_cred(cifs_sb
))
683 create_options
|= CREATE_OPEN_BACKUP_INTENT
;
685 if (server
->ops
->get_lease_key
)
686 server
->ops
->get_lease_key(inode
, &cfile
->fid
);
689 oparms
.cifs_sb
= cifs_sb
;
690 oparms
.desired_access
= desired_access
;
691 oparms
.create_options
= create_options
;
692 oparms
.disposition
= disposition
;
693 oparms
.path
= full_path
;
694 oparms
.fid
= &cfile
->fid
;
695 oparms
.reconnect
= true;
698 * Can not refresh inode by passing in file_info buf to be returned by
699 * ops->open and then calling get_inode_info with returned buf since
700 * file might have write behind data that needs to be flushed and server
701 * version of file size can be stale. If we knew for sure that inode was
702 * not dirty locally we could do this.
704 rc
= server
->ops
->open(xid
, &oparms
, &oplock
, NULL
);
705 if (rc
== -ENOENT
&& oparms
.reconnect
== false) {
706 /* durable handle timeout is expired - open the file again */
707 rc
= server
->ops
->open(xid
, &oparms
, &oplock
, NULL
);
708 /* indicate that we need to relock the file */
709 oparms
.reconnect
= true;
713 mutex_unlock(&cfile
->fh_mutex
);
714 cifs_dbg(FYI
, "cifs_reopen returned 0x%x\n", rc
);
715 cifs_dbg(FYI
, "oplock: %d\n", oplock
);
716 goto reopen_error_exit
;
720 cfile
->invalidHandle
= false;
721 mutex_unlock(&cfile
->fh_mutex
);
722 cinode
= CIFS_I(inode
);
725 rc
= filemap_write_and_wait(inode
->i_mapping
);
726 mapping_set_error(inode
->i_mapping
, rc
);
729 rc
= cifs_get_inode_info_unix(&inode
, full_path
,
732 rc
= cifs_get_inode_info(&inode
, full_path
, NULL
,
733 inode
->i_sb
, xid
, NULL
);
736 * Else we are writing out data to server already and could deadlock if
737 * we tried to flush data, and since we do not know if we have data that
738 * would invalidate the current end of file on the server we can not go
739 * to the server to get the new inode info.
743 * If the server returned a read oplock and we have mandatory brlocks,
744 * set oplock level to None.
746 if (server
->ops
->is_read_op(oplock
) && cifs_has_mand_locks(cinode
)) {
747 cifs_dbg(FYI
, "Reset oplock val from read to None due to mand locks\n");
751 server
->ops
->set_fid(cfile
, &cfile
->fid
, oplock
);
752 if (oparms
.reconnect
)
753 cifs_relock_file(cfile
);
761 int cifs_close(struct inode
*inode
, struct file
*file
)
763 if (file
->private_data
!= NULL
) {
764 cifsFileInfo_put(file
->private_data
);
765 file
->private_data
= NULL
;
768 /* return code from the ->release op is always ignored */
773 cifs_reopen_persistent_handles(struct cifs_tcon
*tcon
)
775 struct cifsFileInfo
*open_file
;
776 struct list_head
*tmp
;
777 struct list_head
*tmp1
;
778 struct list_head tmp_list
;
780 if (!tcon
->use_persistent
|| !tcon
->need_reopen_files
)
783 tcon
->need_reopen_files
= false;
785 cifs_dbg(FYI
, "Reopen persistent handles");
786 INIT_LIST_HEAD(&tmp_list
);
788 /* list all files open on tree connection, reopen resilient handles */
789 spin_lock(&tcon
->open_file_lock
);
790 list_for_each(tmp
, &tcon
->openFileList
) {
791 open_file
= list_entry(tmp
, struct cifsFileInfo
, tlist
);
792 if (!open_file
->invalidHandle
)
794 cifsFileInfo_get(open_file
);
795 list_add_tail(&open_file
->rlist
, &tmp_list
);
797 spin_unlock(&tcon
->open_file_lock
);
799 list_for_each_safe(tmp
, tmp1
, &tmp_list
) {
800 open_file
= list_entry(tmp
, struct cifsFileInfo
, rlist
);
801 if (cifs_reopen_file(open_file
, false /* do not flush */))
802 tcon
->need_reopen_files
= true;
803 list_del_init(&open_file
->rlist
);
804 cifsFileInfo_put(open_file
);
808 int cifs_closedir(struct inode
*inode
, struct file
*file
)
812 struct cifsFileInfo
*cfile
= file
->private_data
;
813 struct cifs_tcon
*tcon
;
814 struct TCP_Server_Info
*server
;
817 cifs_dbg(FYI
, "Closedir inode = 0x%p\n", inode
);
823 tcon
= tlink_tcon(cfile
->tlink
);
824 server
= tcon
->ses
->server
;
826 cifs_dbg(FYI
, "Freeing private data in close dir\n");
827 spin_lock(&cfile
->file_info_lock
);
828 if (server
->ops
->dir_needs_close(cfile
)) {
829 cfile
->invalidHandle
= true;
830 spin_unlock(&cfile
->file_info_lock
);
831 if (server
->ops
->close_dir
)
832 rc
= server
->ops
->close_dir(xid
, tcon
, &cfile
->fid
);
835 cifs_dbg(FYI
, "Closing uncompleted readdir with rc %d\n", rc
);
836 /* not much we can do if it fails anyway, ignore rc */
839 spin_unlock(&cfile
->file_info_lock
);
841 buf
= cfile
->srch_inf
.ntwrk_buf_start
;
843 cifs_dbg(FYI
, "closedir free smb buf in srch struct\n");
844 cfile
->srch_inf
.ntwrk_buf_start
= NULL
;
845 if (cfile
->srch_inf
.smallBuf
)
846 cifs_small_buf_release(buf
);
848 cifs_buf_release(buf
);
851 cifs_put_tlink(cfile
->tlink
);
852 kfree(file
->private_data
);
853 file
->private_data
= NULL
;
854 /* BB can we lock the filestruct while this is going on? */
859 static struct cifsLockInfo
*
860 cifs_lock_init(__u64 offset
, __u64 length
, __u8 type
)
862 struct cifsLockInfo
*lock
=
863 kmalloc(sizeof(struct cifsLockInfo
), GFP_KERNEL
);
866 lock
->offset
= offset
;
867 lock
->length
= length
;
869 lock
->pid
= current
->tgid
;
870 INIT_LIST_HEAD(&lock
->blist
);
871 init_waitqueue_head(&lock
->block_q
);
876 cifs_del_lock_waiters(struct cifsLockInfo
*lock
)
878 struct cifsLockInfo
*li
, *tmp
;
879 list_for_each_entry_safe(li
, tmp
, &lock
->blist
, blist
) {
880 list_del_init(&li
->blist
);
881 wake_up(&li
->block_q
);
885 #define CIFS_LOCK_OP 0
886 #define CIFS_READ_OP 1
887 #define CIFS_WRITE_OP 2
889 /* @rw_check : 0 - no op, 1 - read, 2 - write */
891 cifs_find_fid_lock_conflict(struct cifs_fid_locks
*fdlocks
, __u64 offset
,
892 __u64 length
, __u8 type
, struct cifsFileInfo
*cfile
,
893 struct cifsLockInfo
**conf_lock
, int rw_check
)
895 struct cifsLockInfo
*li
;
896 struct cifsFileInfo
*cur_cfile
= fdlocks
->cfile
;
897 struct TCP_Server_Info
*server
= tlink_tcon(cfile
->tlink
)->ses
->server
;
899 list_for_each_entry(li
, &fdlocks
->locks
, llist
) {
900 if (offset
+ length
<= li
->offset
||
901 offset
>= li
->offset
+ li
->length
)
903 if (rw_check
!= CIFS_LOCK_OP
&& current
->tgid
== li
->pid
&&
904 server
->ops
->compare_fids(cfile
, cur_cfile
)) {
905 /* shared lock prevents write op through the same fid */
906 if (!(li
->type
& server
->vals
->shared_lock_type
) ||
907 rw_check
!= CIFS_WRITE_OP
)
910 if ((type
& server
->vals
->shared_lock_type
) &&
911 ((server
->ops
->compare_fids(cfile
, cur_cfile
) &&
912 current
->tgid
== li
->pid
) || type
== li
->type
))
922 cifs_find_lock_conflict(struct cifsFileInfo
*cfile
, __u64 offset
, __u64 length
,
923 __u8 type
, struct cifsLockInfo
**conf_lock
,
927 struct cifs_fid_locks
*cur
;
928 struct cifsInodeInfo
*cinode
= CIFS_I(d_inode(cfile
->dentry
));
930 list_for_each_entry(cur
, &cinode
->llist
, llist
) {
931 rc
= cifs_find_fid_lock_conflict(cur
, offset
, length
, type
,
932 cfile
, conf_lock
, rw_check
);
941 * Check if there is another lock that prevents us to set the lock (mandatory
942 * style). If such a lock exists, update the flock structure with its
943 * properties. Otherwise, set the flock type to F_UNLCK if we can cache brlocks
944 * or leave it the same if we can't. Returns 0 if we don't need to request to
945 * the server or 1 otherwise.
948 cifs_lock_test(struct cifsFileInfo
*cfile
, __u64 offset
, __u64 length
,
949 __u8 type
, struct file_lock
*flock
)
952 struct cifsLockInfo
*conf_lock
;
953 struct cifsInodeInfo
*cinode
= CIFS_I(d_inode(cfile
->dentry
));
954 struct TCP_Server_Info
*server
= tlink_tcon(cfile
->tlink
)->ses
->server
;
957 down_read(&cinode
->lock_sem
);
959 exist
= cifs_find_lock_conflict(cfile
, offset
, length
, type
,
960 &conf_lock
, CIFS_LOCK_OP
);
962 flock
->fl_start
= conf_lock
->offset
;
963 flock
->fl_end
= conf_lock
->offset
+ conf_lock
->length
- 1;
964 flock
->fl_pid
= conf_lock
->pid
;
965 if (conf_lock
->type
& server
->vals
->shared_lock_type
)
966 flock
->fl_type
= F_RDLCK
;
968 flock
->fl_type
= F_WRLCK
;
969 } else if (!cinode
->can_cache_brlcks
)
972 flock
->fl_type
= F_UNLCK
;
974 up_read(&cinode
->lock_sem
);
979 cifs_lock_add(struct cifsFileInfo
*cfile
, struct cifsLockInfo
*lock
)
981 struct cifsInodeInfo
*cinode
= CIFS_I(d_inode(cfile
->dentry
));
982 down_write(&cinode
->lock_sem
);
983 list_add_tail(&lock
->llist
, &cfile
->llist
->locks
);
984 up_write(&cinode
->lock_sem
);
988 * Set the byte-range lock (mandatory style). Returns:
989 * 1) 0, if we set the lock and don't need to request to the server;
990 * 2) 1, if no locks prevent us but we need to request to the server;
991 * 3) -EACCESS, if there is a lock that prevents us and wait is false.
994 cifs_lock_add_if(struct cifsFileInfo
*cfile
, struct cifsLockInfo
*lock
,
997 struct cifsLockInfo
*conf_lock
;
998 struct cifsInodeInfo
*cinode
= CIFS_I(d_inode(cfile
->dentry
));
1004 down_write(&cinode
->lock_sem
);
1006 exist
= cifs_find_lock_conflict(cfile
, lock
->offset
, lock
->length
,
1007 lock
->type
, &conf_lock
, CIFS_LOCK_OP
);
1008 if (!exist
&& cinode
->can_cache_brlcks
) {
1009 list_add_tail(&lock
->llist
, &cfile
->llist
->locks
);
1010 up_write(&cinode
->lock_sem
);
1019 list_add_tail(&lock
->blist
, &conf_lock
->blist
);
1020 up_write(&cinode
->lock_sem
);
1021 rc
= wait_event_interruptible(lock
->block_q
,
1022 (lock
->blist
.prev
== &lock
->blist
) &&
1023 (lock
->blist
.next
== &lock
->blist
));
1026 down_write(&cinode
->lock_sem
);
1027 list_del_init(&lock
->blist
);
1030 up_write(&cinode
->lock_sem
);
1035 * Check if there is another lock that prevents us to set the lock (posix
1036 * style). If such a lock exists, update the flock structure with its
1037 * properties. Otherwise, set the flock type to F_UNLCK if we can cache brlocks
1038 * or leave it the same if we can't. Returns 0 if we don't need to request to
1039 * the server or 1 otherwise.
1042 cifs_posix_lock_test(struct file
*file
, struct file_lock
*flock
)
1045 struct cifsInodeInfo
*cinode
= CIFS_I(file_inode(file
));
1046 unsigned char saved_type
= flock
->fl_type
;
1048 if ((flock
->fl_flags
& FL_POSIX
) == 0)
1051 down_read(&cinode
->lock_sem
);
1052 posix_test_lock(file
, flock
);
1054 if (flock
->fl_type
== F_UNLCK
&& !cinode
->can_cache_brlcks
) {
1055 flock
->fl_type
= saved_type
;
1059 up_read(&cinode
->lock_sem
);
1064 * Set the byte-range lock (posix style). Returns:
1065 * 1) 0, if we set the lock and don't need to request to the server;
1066 * 2) 1, if we need to request to the server;
1067 * 3) <0, if the error occurs while setting the lock.
1070 cifs_posix_lock_set(struct file
*file
, struct file_lock
*flock
)
1072 struct cifsInodeInfo
*cinode
= CIFS_I(file_inode(file
));
1075 if ((flock
->fl_flags
& FL_POSIX
) == 0)
1079 down_write(&cinode
->lock_sem
);
1080 if (!cinode
->can_cache_brlcks
) {
1081 up_write(&cinode
->lock_sem
);
1085 rc
= posix_lock_file(file
, flock
, NULL
);
1086 up_write(&cinode
->lock_sem
);
1087 if (rc
== FILE_LOCK_DEFERRED
) {
1088 rc
= wait_event_interruptible(flock
->fl_wait
, !flock
->fl_next
);
1091 posix_unblock_lock(flock
);
1097 cifs_push_mandatory_locks(struct cifsFileInfo
*cfile
)
1100 int rc
= 0, stored_rc
;
1101 struct cifsLockInfo
*li
, *tmp
;
1102 struct cifs_tcon
*tcon
;
1103 unsigned int num
, max_num
, max_buf
;
1104 LOCKING_ANDX_RANGE
*buf
, *cur
;
1105 int types
[] = {LOCKING_ANDX_LARGE_FILES
,
1106 LOCKING_ANDX_SHARED_LOCK
| LOCKING_ANDX_LARGE_FILES
};
1110 tcon
= tlink_tcon(cfile
->tlink
);
1113 * Accessing maxBuf is racy with cifs_reconnect - need to store value
1114 * and check it for zero before using.
1116 max_buf
= tcon
->ses
->server
->maxBuf
;
1122 max_num
= (max_buf
- sizeof(struct smb_hdr
)) /
1123 sizeof(LOCKING_ANDX_RANGE
);
1124 buf
= kcalloc(max_num
, sizeof(LOCKING_ANDX_RANGE
), GFP_KERNEL
);
1130 for (i
= 0; i
< 2; i
++) {
1133 list_for_each_entry_safe(li
, tmp
, &cfile
->llist
->locks
, llist
) {
1134 if (li
->type
!= types
[i
])
1136 cur
->Pid
= cpu_to_le16(li
->pid
);
1137 cur
->LengthLow
= cpu_to_le32((u32
)li
->length
);
1138 cur
->LengthHigh
= cpu_to_le32((u32
)(li
->length
>>32));
1139 cur
->OffsetLow
= cpu_to_le32((u32
)li
->offset
);
1140 cur
->OffsetHigh
= cpu_to_le32((u32
)(li
->offset
>>32));
1141 if (++num
== max_num
) {
1142 stored_rc
= cifs_lockv(xid
, tcon
,
1144 (__u8
)li
->type
, 0, num
,
1155 stored_rc
= cifs_lockv(xid
, tcon
, cfile
->fid
.netfid
,
1156 (__u8
)types
[i
], 0, num
, buf
);
1168 hash_lockowner(fl_owner_t owner
)
1170 return cifs_lock_secret
^ hash32_ptr((const void *)owner
);
1173 struct lock_to_push
{
1174 struct list_head llist
;
1183 cifs_push_posix_locks(struct cifsFileInfo
*cfile
)
1185 struct inode
*inode
= d_inode(cfile
->dentry
);
1186 struct cifs_tcon
*tcon
= tlink_tcon(cfile
->tlink
);
1187 struct file_lock
*flock
;
1188 struct file_lock_context
*flctx
= inode
->i_flctx
;
1189 unsigned int count
= 0, i
;
1190 int rc
= 0, xid
, type
;
1191 struct list_head locks_to_send
, *el
;
1192 struct lock_to_push
*lck
, *tmp
;
1200 spin_lock(&flctx
->flc_lock
);
1201 list_for_each(el
, &flctx
->flc_posix
) {
1204 spin_unlock(&flctx
->flc_lock
);
1206 INIT_LIST_HEAD(&locks_to_send
);
1209 * Allocating count locks is enough because no FL_POSIX locks can be
1210 * added to the list while we are holding cinode->lock_sem that
1211 * protects locking operations of this inode.
1213 for (i
= 0; i
< count
; i
++) {
1214 lck
= kmalloc(sizeof(struct lock_to_push
), GFP_KERNEL
);
1219 list_add_tail(&lck
->llist
, &locks_to_send
);
1222 el
= locks_to_send
.next
;
1223 spin_lock(&flctx
->flc_lock
);
1224 list_for_each_entry(flock
, &flctx
->flc_posix
, fl_list
) {
1225 if (el
== &locks_to_send
) {
1227 * The list ended. We don't have enough allocated
1228 * structures - something is really wrong.
1230 cifs_dbg(VFS
, "Can't push all brlocks!\n");
1233 length
= 1 + flock
->fl_end
- flock
->fl_start
;
1234 if (flock
->fl_type
== F_RDLCK
|| flock
->fl_type
== F_SHLCK
)
1238 lck
= list_entry(el
, struct lock_to_push
, llist
);
1239 lck
->pid
= hash_lockowner(flock
->fl_owner
);
1240 lck
->netfid
= cfile
->fid
.netfid
;
1241 lck
->length
= length
;
1243 lck
->offset
= flock
->fl_start
;
1245 spin_unlock(&flctx
->flc_lock
);
1247 list_for_each_entry_safe(lck
, tmp
, &locks_to_send
, llist
) {
1250 stored_rc
= CIFSSMBPosixLock(xid
, tcon
, lck
->netfid
, lck
->pid
,
1251 lck
->offset
, lck
->length
, NULL
,
1255 list_del(&lck
->llist
);
1263 list_for_each_entry_safe(lck
, tmp
, &locks_to_send
, llist
) {
1264 list_del(&lck
->llist
);
1271 cifs_push_locks(struct cifsFileInfo
*cfile
)
1273 struct cifs_sb_info
*cifs_sb
= CIFS_SB(cfile
->dentry
->d_sb
);
1274 struct cifsInodeInfo
*cinode
= CIFS_I(d_inode(cfile
->dentry
));
1275 struct cifs_tcon
*tcon
= tlink_tcon(cfile
->tlink
);
1278 /* we are going to update can_cache_brlcks here - need a write access */
1279 down_write(&cinode
->lock_sem
);
1280 if (!cinode
->can_cache_brlcks
) {
1281 up_write(&cinode
->lock_sem
);
1285 if (cap_unix(tcon
->ses
) &&
1286 (CIFS_UNIX_FCNTL_CAP
& le64_to_cpu(tcon
->fsUnixInfo
.Capability
)) &&
1287 ((cifs_sb
->mnt_cifs_flags
& CIFS_MOUNT_NOPOSIXBRL
) == 0))
1288 rc
= cifs_push_posix_locks(cfile
);
1290 rc
= tcon
->ses
->server
->ops
->push_mand_locks(cfile
);
1292 cinode
->can_cache_brlcks
= false;
1293 up_write(&cinode
->lock_sem
);
1298 cifs_read_flock(struct file_lock
*flock
, __u32
*type
, int *lock
, int *unlock
,
1299 bool *wait_flag
, struct TCP_Server_Info
*server
)
1301 if (flock
->fl_flags
& FL_POSIX
)
1302 cifs_dbg(FYI
, "Posix\n");
1303 if (flock
->fl_flags
& FL_FLOCK
)
1304 cifs_dbg(FYI
, "Flock\n");
1305 if (flock
->fl_flags
& FL_SLEEP
) {
1306 cifs_dbg(FYI
, "Blocking lock\n");
1309 if (flock
->fl_flags
& FL_ACCESS
)
1310 cifs_dbg(FYI
, "Process suspended by mandatory locking - not implemented yet\n");
1311 if (flock
->fl_flags
& FL_LEASE
)
1312 cifs_dbg(FYI
, "Lease on file - not implemented yet\n");
1313 if (flock
->fl_flags
&
1314 (~(FL_POSIX
| FL_FLOCK
| FL_SLEEP
|
1315 FL_ACCESS
| FL_LEASE
| FL_CLOSE
)))
1316 cifs_dbg(FYI
, "Unknown lock flags 0x%x\n", flock
->fl_flags
);
1318 *type
= server
->vals
->large_lock_type
;
1319 if (flock
->fl_type
== F_WRLCK
) {
1320 cifs_dbg(FYI
, "F_WRLCK\n");
1321 *type
|= server
->vals
->exclusive_lock_type
;
1323 } else if (flock
->fl_type
== F_UNLCK
) {
1324 cifs_dbg(FYI
, "F_UNLCK\n");
1325 *type
|= server
->vals
->unlock_lock_type
;
1327 /* Check if unlock includes more than one lock range */
1328 } else if (flock
->fl_type
== F_RDLCK
) {
1329 cifs_dbg(FYI
, "F_RDLCK\n");
1330 *type
|= server
->vals
->shared_lock_type
;
1332 } else if (flock
->fl_type
== F_EXLCK
) {
1333 cifs_dbg(FYI
, "F_EXLCK\n");
1334 *type
|= server
->vals
->exclusive_lock_type
;
1336 } else if (flock
->fl_type
== F_SHLCK
) {
1337 cifs_dbg(FYI
, "F_SHLCK\n");
1338 *type
|= server
->vals
->shared_lock_type
;
1341 cifs_dbg(FYI
, "Unknown type of lock\n");
1345 cifs_getlk(struct file
*file
, struct file_lock
*flock
, __u32 type
,
1346 bool wait_flag
, bool posix_lck
, unsigned int xid
)
1349 __u64 length
= 1 + flock
->fl_end
- flock
->fl_start
;
1350 struct cifsFileInfo
*cfile
= (struct cifsFileInfo
*)file
->private_data
;
1351 struct cifs_tcon
*tcon
= tlink_tcon(cfile
->tlink
);
1352 struct TCP_Server_Info
*server
= tcon
->ses
->server
;
1353 __u16 netfid
= cfile
->fid
.netfid
;
1356 int posix_lock_type
;
1358 rc
= cifs_posix_lock_test(file
, flock
);
1362 if (type
& server
->vals
->shared_lock_type
)
1363 posix_lock_type
= CIFS_RDLCK
;
1365 posix_lock_type
= CIFS_WRLCK
;
1366 rc
= CIFSSMBPosixLock(xid
, tcon
, netfid
,
1367 hash_lockowner(flock
->fl_owner
),
1368 flock
->fl_start
, length
, flock
,
1369 posix_lock_type
, wait_flag
);
1373 rc
= cifs_lock_test(cfile
, flock
->fl_start
, length
, type
, flock
);
1377 /* BB we could chain these into one lock request BB */
1378 rc
= server
->ops
->mand_lock(xid
, cfile
, flock
->fl_start
, length
, type
,
1381 rc
= server
->ops
->mand_lock(xid
, cfile
, flock
->fl_start
, length
,
1383 flock
->fl_type
= F_UNLCK
;
1385 cifs_dbg(VFS
, "Error unlocking previously locked range %d during test of lock\n",
1390 if (type
& server
->vals
->shared_lock_type
) {
1391 flock
->fl_type
= F_WRLCK
;
1395 type
&= ~server
->vals
->exclusive_lock_type
;
1397 rc
= server
->ops
->mand_lock(xid
, cfile
, flock
->fl_start
, length
,
1398 type
| server
->vals
->shared_lock_type
,
1401 rc
= server
->ops
->mand_lock(xid
, cfile
, flock
->fl_start
, length
,
1402 type
| server
->vals
->shared_lock_type
, 0, 1, false);
1403 flock
->fl_type
= F_RDLCK
;
1405 cifs_dbg(VFS
, "Error unlocking previously locked range %d during test of lock\n",
1408 flock
->fl_type
= F_WRLCK
;
1414 cifs_move_llist(struct list_head
*source
, struct list_head
*dest
)
1416 struct list_head
*li
, *tmp
;
1417 list_for_each_safe(li
, tmp
, source
)
1418 list_move(li
, dest
);
1422 cifs_free_llist(struct list_head
*llist
)
1424 struct cifsLockInfo
*li
, *tmp
;
1425 list_for_each_entry_safe(li
, tmp
, llist
, llist
) {
1426 cifs_del_lock_waiters(li
);
1427 list_del(&li
->llist
);
1433 cifs_unlock_range(struct cifsFileInfo
*cfile
, struct file_lock
*flock
,
1436 int rc
= 0, stored_rc
;
1437 int types
[] = {LOCKING_ANDX_LARGE_FILES
,
1438 LOCKING_ANDX_SHARED_LOCK
| LOCKING_ANDX_LARGE_FILES
};
1440 unsigned int max_num
, num
, max_buf
;
1441 LOCKING_ANDX_RANGE
*buf
, *cur
;
1442 struct cifs_tcon
*tcon
= tlink_tcon(cfile
->tlink
);
1443 struct cifsInodeInfo
*cinode
= CIFS_I(d_inode(cfile
->dentry
));
1444 struct cifsLockInfo
*li
, *tmp
;
1445 __u64 length
= 1 + flock
->fl_end
- flock
->fl_start
;
1446 struct list_head tmp_llist
;
1448 INIT_LIST_HEAD(&tmp_llist
);
1451 * Accessing maxBuf is racy with cifs_reconnect - need to store value
1452 * and check it for zero before using.
1454 max_buf
= tcon
->ses
->server
->maxBuf
;
1458 max_num
= (max_buf
- sizeof(struct smb_hdr
)) /
1459 sizeof(LOCKING_ANDX_RANGE
);
1460 buf
= kcalloc(max_num
, sizeof(LOCKING_ANDX_RANGE
), GFP_KERNEL
);
1464 down_write(&cinode
->lock_sem
);
1465 for (i
= 0; i
< 2; i
++) {
1468 list_for_each_entry_safe(li
, tmp
, &cfile
->llist
->locks
, llist
) {
1469 if (flock
->fl_start
> li
->offset
||
1470 (flock
->fl_start
+ length
) <
1471 (li
->offset
+ li
->length
))
1473 if (current
->tgid
!= li
->pid
)
1475 if (types
[i
] != li
->type
)
1477 if (cinode
->can_cache_brlcks
) {
1479 * We can cache brlock requests - simply remove
1480 * a lock from the file's list.
1482 list_del(&li
->llist
);
1483 cifs_del_lock_waiters(li
);
1487 cur
->Pid
= cpu_to_le16(li
->pid
);
1488 cur
->LengthLow
= cpu_to_le32((u32
)li
->length
);
1489 cur
->LengthHigh
= cpu_to_le32((u32
)(li
->length
>>32));
1490 cur
->OffsetLow
= cpu_to_le32((u32
)li
->offset
);
1491 cur
->OffsetHigh
= cpu_to_le32((u32
)(li
->offset
>>32));
1493 * We need to save a lock here to let us add it again to
1494 * the file's list if the unlock range request fails on
1497 list_move(&li
->llist
, &tmp_llist
);
1498 if (++num
== max_num
) {
1499 stored_rc
= cifs_lockv(xid
, tcon
,
1501 li
->type
, num
, 0, buf
);
1504 * We failed on the unlock range
1505 * request - add all locks from the tmp
1506 * list to the head of the file's list.
1508 cifs_move_llist(&tmp_llist
,
1509 &cfile
->llist
->locks
);
1513 * The unlock range request succeed -
1514 * free the tmp list.
1516 cifs_free_llist(&tmp_llist
);
1523 stored_rc
= cifs_lockv(xid
, tcon
, cfile
->fid
.netfid
,
1524 types
[i
], num
, 0, buf
);
1526 cifs_move_llist(&tmp_llist
,
1527 &cfile
->llist
->locks
);
1530 cifs_free_llist(&tmp_llist
);
1534 up_write(&cinode
->lock_sem
);
1540 cifs_setlk(struct file
*file
, struct file_lock
*flock
, __u32 type
,
1541 bool wait_flag
, bool posix_lck
, int lock
, int unlock
,
1545 __u64 length
= 1 + flock
->fl_end
- flock
->fl_start
;
1546 struct cifsFileInfo
*cfile
= (struct cifsFileInfo
*)file
->private_data
;
1547 struct cifs_tcon
*tcon
= tlink_tcon(cfile
->tlink
);
1548 struct TCP_Server_Info
*server
= tcon
->ses
->server
;
1549 struct inode
*inode
= d_inode(cfile
->dentry
);
1552 int posix_lock_type
;
1554 rc
= cifs_posix_lock_set(file
, flock
);
1558 if (type
& server
->vals
->shared_lock_type
)
1559 posix_lock_type
= CIFS_RDLCK
;
1561 posix_lock_type
= CIFS_WRLCK
;
1564 posix_lock_type
= CIFS_UNLCK
;
1566 rc
= CIFSSMBPosixLock(xid
, tcon
, cfile
->fid
.netfid
,
1567 hash_lockowner(flock
->fl_owner
),
1568 flock
->fl_start
, length
,
1569 NULL
, posix_lock_type
, wait_flag
);
1574 struct cifsLockInfo
*lock
;
1576 lock
= cifs_lock_init(flock
->fl_start
, length
, type
);
1580 rc
= cifs_lock_add_if(cfile
, lock
, wait_flag
);
1589 * Windows 7 server can delay breaking lease from read to None
1590 * if we set a byte-range lock on a file - break it explicitly
1591 * before sending the lock to the server to be sure the next
1592 * read won't conflict with non-overlapted locks due to
1595 if (!CIFS_CACHE_WRITE(CIFS_I(inode
)) &&
1596 CIFS_CACHE_READ(CIFS_I(inode
))) {
1597 cifs_zap_mapping(inode
);
1598 cifs_dbg(FYI
, "Set no oplock for inode=%p due to mand locks\n",
1600 CIFS_I(inode
)->oplock
= 0;
1603 rc
= server
->ops
->mand_lock(xid
, cfile
, flock
->fl_start
, length
,
1604 type
, 1, 0, wait_flag
);
1610 cifs_lock_add(cfile
, lock
);
1612 rc
= server
->ops
->mand_unlock_range(cfile
, flock
, xid
);
1615 if (flock
->fl_flags
& FL_POSIX
&& !rc
)
1616 rc
= locks_lock_file_wait(file
, flock
);
1620 int cifs_lock(struct file
*file
, int cmd
, struct file_lock
*flock
)
1623 int lock
= 0, unlock
= 0;
1624 bool wait_flag
= false;
1625 bool posix_lck
= false;
1626 struct cifs_sb_info
*cifs_sb
;
1627 struct cifs_tcon
*tcon
;
1628 struct cifsInodeInfo
*cinode
;
1629 struct cifsFileInfo
*cfile
;
1636 cifs_dbg(FYI
, "Lock parm: 0x%x flockflags: 0x%x flocktype: 0x%x start: %lld end: %lld\n",
1637 cmd
, flock
->fl_flags
, flock
->fl_type
,
1638 flock
->fl_start
, flock
->fl_end
);
1640 cfile
= (struct cifsFileInfo
*)file
->private_data
;
1641 tcon
= tlink_tcon(cfile
->tlink
);
1643 cifs_read_flock(flock
, &type
, &lock
, &unlock
, &wait_flag
,
1646 cifs_sb
= CIFS_FILE_SB(file
);
1647 netfid
= cfile
->fid
.netfid
;
1648 cinode
= CIFS_I(file_inode(file
));
1650 if (cap_unix(tcon
->ses
) &&
1651 (CIFS_UNIX_FCNTL_CAP
& le64_to_cpu(tcon
->fsUnixInfo
.Capability
)) &&
1652 ((cifs_sb
->mnt_cifs_flags
& CIFS_MOUNT_NOPOSIXBRL
) == 0))
1655 * BB add code here to normalize offset and length to account for
1656 * negative length which we can not accept over the wire.
1658 if (IS_GETLK(cmd
)) {
1659 rc
= cifs_getlk(file
, flock
, type
, wait_flag
, posix_lck
, xid
);
1664 if (!lock
&& !unlock
) {
1666 * if no lock or unlock then nothing to do since we do not
1673 rc
= cifs_setlk(file
, flock
, type
, wait_flag
, posix_lck
, lock
, unlock
,
1680 * update the file size (if needed) after a write. Should be called with
1681 * the inode->i_lock held
1684 cifs_update_eof(struct cifsInodeInfo
*cifsi
, loff_t offset
,
1685 unsigned int bytes_written
)
1687 loff_t end_of_write
= offset
+ bytes_written
;
1689 if (end_of_write
> cifsi
->server_eof
)
1690 cifsi
->server_eof
= end_of_write
;
1694 cifs_write(struct cifsFileInfo
*open_file
, __u32 pid
, const char *write_data
,
1695 size_t write_size
, loff_t
*offset
)
1698 unsigned int bytes_written
= 0;
1699 unsigned int total_written
;
1700 struct cifs_sb_info
*cifs_sb
;
1701 struct cifs_tcon
*tcon
;
1702 struct TCP_Server_Info
*server
;
1704 struct dentry
*dentry
= open_file
->dentry
;
1705 struct cifsInodeInfo
*cifsi
= CIFS_I(d_inode(dentry
));
1706 struct cifs_io_parms io_parms
;
1708 cifs_sb
= CIFS_SB(dentry
->d_sb
);
1710 cifs_dbg(FYI
, "write %zd bytes to offset %lld of %pd\n",
1711 write_size
, *offset
, dentry
);
1713 tcon
= tlink_tcon(open_file
->tlink
);
1714 server
= tcon
->ses
->server
;
1716 if (!server
->ops
->sync_write
)
1721 for (total_written
= 0; write_size
> total_written
;
1722 total_written
+= bytes_written
) {
1724 while (rc
== -EAGAIN
) {
1728 if (open_file
->invalidHandle
) {
1729 /* we could deadlock if we called
1730 filemap_fdatawait from here so tell
1731 reopen_file not to flush data to
1733 rc
= cifs_reopen_file(open_file
, false);
1738 len
= min(server
->ops
->wp_retry_size(d_inode(dentry
)),
1739 (unsigned int)write_size
- total_written
);
1740 /* iov[0] is reserved for smb header */
1741 iov
[1].iov_base
= (char *)write_data
+ total_written
;
1742 iov
[1].iov_len
= len
;
1744 io_parms
.tcon
= tcon
;
1745 io_parms
.offset
= *offset
;
1746 io_parms
.length
= len
;
1747 rc
= server
->ops
->sync_write(xid
, &open_file
->fid
,
1748 &io_parms
, &bytes_written
, iov
, 1);
1750 if (rc
|| (bytes_written
== 0)) {
1758 spin_lock(&d_inode(dentry
)->i_lock
);
1759 cifs_update_eof(cifsi
, *offset
, bytes_written
);
1760 spin_unlock(&d_inode(dentry
)->i_lock
);
1761 *offset
+= bytes_written
;
1765 cifs_stats_bytes_written(tcon
, total_written
);
1767 if (total_written
> 0) {
1768 spin_lock(&d_inode(dentry
)->i_lock
);
1769 if (*offset
> d_inode(dentry
)->i_size
)
1770 i_size_write(d_inode(dentry
), *offset
);
1771 spin_unlock(&d_inode(dentry
)->i_lock
);
1773 mark_inode_dirty_sync(d_inode(dentry
));
1775 return total_written
;
1778 struct cifsFileInfo
*find_readable_file(struct cifsInodeInfo
*cifs_inode
,
1781 struct cifsFileInfo
*open_file
= NULL
;
1782 struct cifs_sb_info
*cifs_sb
= CIFS_SB(cifs_inode
->vfs_inode
.i_sb
);
1783 struct cifs_tcon
*tcon
= cifs_sb_master_tcon(cifs_sb
);
1785 /* only filter by fsuid on multiuser mounts */
1786 if (!(cifs_sb
->mnt_cifs_flags
& CIFS_MOUNT_MULTIUSER
))
1789 spin_lock(&tcon
->open_file_lock
);
1790 /* we could simply get the first_list_entry since write-only entries
1791 are always at the end of the list but since the first entry might
1792 have a close pending, we go through the whole list */
1793 list_for_each_entry(open_file
, &cifs_inode
->openFileList
, flist
) {
1794 if (fsuid_only
&& !uid_eq(open_file
->uid
, current_fsuid()))
1796 if (OPEN_FMODE(open_file
->f_flags
) & FMODE_READ
) {
1797 if (!open_file
->invalidHandle
) {
1798 /* found a good file */
1799 /* lock it so it will not be closed on us */
1800 cifsFileInfo_get(open_file
);
1801 spin_unlock(&tcon
->open_file_lock
);
1803 } /* else might as well continue, and look for
1804 another, or simply have the caller reopen it
1805 again rather than trying to fix this handle */
1806 } else /* write only file */
1807 break; /* write only files are last so must be done */
1809 spin_unlock(&tcon
->open_file_lock
);
1813 struct cifsFileInfo
*find_writable_file(struct cifsInodeInfo
*cifs_inode
,
1816 struct cifsFileInfo
*open_file
, *inv_file
= NULL
;
1817 struct cifs_sb_info
*cifs_sb
;
1818 struct cifs_tcon
*tcon
;
1819 bool any_available
= false;
1821 unsigned int refind
= 0;
1823 /* Having a null inode here (because mapping->host was set to zero by
1824 the VFS or MM) should not happen but we had reports of on oops (due to
1825 it being zero) during stress testcases so we need to check for it */
1827 if (cifs_inode
== NULL
) {
1828 cifs_dbg(VFS
, "Null inode passed to cifs_writeable_file\n");
1833 cifs_sb
= CIFS_SB(cifs_inode
->vfs_inode
.i_sb
);
1834 tcon
= cifs_sb_master_tcon(cifs_sb
);
1836 /* only filter by fsuid on multiuser mounts */
1837 if (!(cifs_sb
->mnt_cifs_flags
& CIFS_MOUNT_MULTIUSER
))
1840 spin_lock(&tcon
->open_file_lock
);
1842 if (refind
> MAX_REOPEN_ATT
) {
1843 spin_unlock(&tcon
->open_file_lock
);
1846 list_for_each_entry(open_file
, &cifs_inode
->openFileList
, flist
) {
1847 if (!any_available
&& open_file
->pid
!= current
->tgid
)
1849 if (fsuid_only
&& !uid_eq(open_file
->uid
, current_fsuid()))
1851 if (OPEN_FMODE(open_file
->f_flags
) & FMODE_WRITE
) {
1852 if (!open_file
->invalidHandle
) {
1853 /* found a good writable file */
1854 cifsFileInfo_get(open_file
);
1855 spin_unlock(&tcon
->open_file_lock
);
1859 inv_file
= open_file
;
1863 /* couldn't find useable FH with same pid, try any available */
1864 if (!any_available
) {
1865 any_available
= true;
1866 goto refind_writable
;
1870 any_available
= false;
1871 cifsFileInfo_get(inv_file
);
1874 spin_unlock(&tcon
->open_file_lock
);
1877 rc
= cifs_reopen_file(inv_file
, false);
1881 spin_lock(&tcon
->open_file_lock
);
1882 list_move_tail(&inv_file
->flist
,
1883 &cifs_inode
->openFileList
);
1884 spin_unlock(&tcon
->open_file_lock
);
1885 cifsFileInfo_put(inv_file
);
1888 spin_lock(&tcon
->open_file_lock
);
1889 goto refind_writable
;
1896 static int cifs_partialpagewrite(struct page
*page
, unsigned from
, unsigned to
)
1898 struct address_space
*mapping
= page
->mapping
;
1899 loff_t offset
= (loff_t
)page
->index
<< PAGE_SHIFT
;
1902 int bytes_written
= 0;
1903 struct inode
*inode
;
1904 struct cifsFileInfo
*open_file
;
1906 if (!mapping
|| !mapping
->host
)
1909 inode
= page
->mapping
->host
;
1911 offset
+= (loff_t
)from
;
1912 write_data
= kmap(page
);
1915 if ((to
> PAGE_SIZE
) || (from
> to
)) {
1920 /* racing with truncate? */
1921 if (offset
> mapping
->host
->i_size
) {
1923 return 0; /* don't care */
1926 /* check to make sure that we are not extending the file */
1927 if (mapping
->host
->i_size
- offset
< (loff_t
)to
)
1928 to
= (unsigned)(mapping
->host
->i_size
- offset
);
1930 open_file
= find_writable_file(CIFS_I(mapping
->host
), false);
1932 bytes_written
= cifs_write(open_file
, open_file
->pid
,
1933 write_data
, to
- from
, &offset
);
1934 cifsFileInfo_put(open_file
);
1935 /* Does mm or vfs already set times? */
1936 inode
->i_atime
= inode
->i_mtime
= current_time(inode
);
1937 if ((bytes_written
> 0) && (offset
))
1939 else if (bytes_written
< 0)
1942 cifs_dbg(FYI
, "No writeable filehandles for inode\n");
1950 static struct cifs_writedata
*
1951 wdata_alloc_and_fillpages(pgoff_t tofind
, struct address_space
*mapping
,
1952 pgoff_t end
, pgoff_t
*index
,
1953 unsigned int *found_pages
)
1955 unsigned int nr_pages
;
1956 struct page
**pages
;
1957 struct cifs_writedata
*wdata
;
1959 wdata
= cifs_writedata_alloc((unsigned int)tofind
,
1960 cifs_writev_complete
);
1965 * find_get_pages_tag seems to return a max of 256 on each
1966 * iteration, so we must call it several times in order to
1967 * fill the array or the wsize is effectively limited to
1971 pages
= wdata
->pages
;
1973 nr_pages
= find_get_pages_tag(mapping
, index
,
1974 PAGECACHE_TAG_DIRTY
, tofind
,
1976 *found_pages
+= nr_pages
;
1979 } while (nr_pages
&& tofind
&& *index
<= end
);
1985 wdata_prepare_pages(struct cifs_writedata
*wdata
, unsigned int found_pages
,
1986 struct address_space
*mapping
,
1987 struct writeback_control
*wbc
,
1988 pgoff_t end
, pgoff_t
*index
, pgoff_t
*next
, bool *done
)
1990 unsigned int nr_pages
= 0, i
;
1993 for (i
= 0; i
< found_pages
; i
++) {
1994 page
= wdata
->pages
[i
];
1996 * At this point we hold neither mapping->tree_lock nor
1997 * lock on the page itself: the page may be truncated or
1998 * invalidated (changing page->mapping to NULL), or even
1999 * swizzled back from swapper_space to tmpfs file
2005 else if (!trylock_page(page
))
2008 if (unlikely(page
->mapping
!= mapping
)) {
2013 if (!wbc
->range_cyclic
&& page
->index
> end
) {
2019 if (*next
&& (page
->index
!= *next
)) {
2020 /* Not next consecutive page */
2025 if (wbc
->sync_mode
!= WB_SYNC_NONE
)
2026 wait_on_page_writeback(page
);
2028 if (PageWriteback(page
) ||
2029 !clear_page_dirty_for_io(page
)) {
2035 * This actually clears the dirty bit in the radix tree.
2036 * See cifs_writepage() for more commentary.
2038 set_page_writeback(page
);
2039 if (page_offset(page
) >= i_size_read(mapping
->host
)) {
2042 end_page_writeback(page
);
2046 wdata
->pages
[i
] = page
;
2047 *next
= page
->index
+ 1;
2051 /* reset index to refind any pages skipped */
2053 *index
= wdata
->pages
[0]->index
+ 1;
2055 /* put any pages we aren't going to use */
2056 for (i
= nr_pages
; i
< found_pages
; i
++) {
2057 put_page(wdata
->pages
[i
]);
2058 wdata
->pages
[i
] = NULL
;
2065 wdata_send_pages(struct cifs_writedata
*wdata
, unsigned int nr_pages
,
2066 struct address_space
*mapping
, struct writeback_control
*wbc
)
2069 struct TCP_Server_Info
*server
;
2072 wdata
->sync_mode
= wbc
->sync_mode
;
2073 wdata
->nr_pages
= nr_pages
;
2074 wdata
->offset
= page_offset(wdata
->pages
[0]);
2075 wdata
->pagesz
= PAGE_SIZE
;
2076 wdata
->tailsz
= min(i_size_read(mapping
->host
) -
2077 page_offset(wdata
->pages
[nr_pages
- 1]),
2079 wdata
->bytes
= ((nr_pages
- 1) * PAGE_SIZE
) + wdata
->tailsz
;
2081 if (wdata
->cfile
!= NULL
)
2082 cifsFileInfo_put(wdata
->cfile
);
2083 wdata
->cfile
= find_writable_file(CIFS_I(mapping
->host
), false);
2084 if (!wdata
->cfile
) {
2085 cifs_dbg(VFS
, "No writable handles for inode\n");
2088 wdata
->pid
= wdata
->cfile
->pid
;
2089 server
= tlink_tcon(wdata
->cfile
->tlink
)->ses
->server
;
2090 rc
= server
->ops
->async_writev(wdata
, cifs_writedata_release
);
2093 for (i
= 0; i
< nr_pages
; ++i
)
2094 unlock_page(wdata
->pages
[i
]);
2099 static int cifs_writepages(struct address_space
*mapping
,
2100 struct writeback_control
*wbc
)
2102 struct cifs_sb_info
*cifs_sb
= CIFS_SB(mapping
->host
->i_sb
);
2103 struct TCP_Server_Info
*server
;
2104 bool done
= false, scanned
= false, range_whole
= false;
2106 struct cifs_writedata
*wdata
;
2110 * If wsize is smaller than the page cache size, default to writing
2111 * one page at a time via cifs_writepage
2113 if (cifs_sb
->wsize
< PAGE_SIZE
)
2114 return generic_writepages(mapping
, wbc
);
2116 if (wbc
->range_cyclic
) {
2117 index
= mapping
->writeback_index
; /* Start from prev offset */
2120 index
= wbc
->range_start
>> PAGE_SHIFT
;
2121 end
= wbc
->range_end
>> PAGE_SHIFT
;
2122 if (wbc
->range_start
== 0 && wbc
->range_end
== LLONG_MAX
)
2126 server
= cifs_sb_master_tcon(cifs_sb
)->ses
->server
;
2128 while (!done
&& index
<= end
) {
2129 unsigned int i
, nr_pages
, found_pages
, wsize
, credits
;
2130 pgoff_t next
= 0, tofind
, saved_index
= index
;
2132 rc
= server
->ops
->wait_mtu_credits(server
, cifs_sb
->wsize
,
2137 tofind
= min((wsize
/ PAGE_SIZE
) - 1, end
- index
) + 1;
2139 wdata
= wdata_alloc_and_fillpages(tofind
, mapping
, end
, &index
,
2143 add_credits_and_wake_if(server
, credits
, 0);
2147 if (found_pages
== 0) {
2148 kref_put(&wdata
->refcount
, cifs_writedata_release
);
2149 add_credits_and_wake_if(server
, credits
, 0);
2153 nr_pages
= wdata_prepare_pages(wdata
, found_pages
, mapping
, wbc
,
2154 end
, &index
, &next
, &done
);
2156 /* nothing to write? */
2157 if (nr_pages
== 0) {
2158 kref_put(&wdata
->refcount
, cifs_writedata_release
);
2159 add_credits_and_wake_if(server
, credits
, 0);
2163 wdata
->credits
= credits
;
2165 rc
= wdata_send_pages(wdata
, nr_pages
, mapping
, wbc
);
2167 /* send failure -- clean up the mess */
2169 add_credits_and_wake_if(server
, wdata
->credits
, 0);
2170 for (i
= 0; i
< nr_pages
; ++i
) {
2172 redirty_page_for_writepage(wbc
,
2175 SetPageError(wdata
->pages
[i
]);
2176 end_page_writeback(wdata
->pages
[i
]);
2177 put_page(wdata
->pages
[i
]);
2180 mapping_set_error(mapping
, rc
);
2182 kref_put(&wdata
->refcount
, cifs_writedata_release
);
2184 if (wbc
->sync_mode
== WB_SYNC_ALL
&& rc
== -EAGAIN
) {
2185 index
= saved_index
;
2189 wbc
->nr_to_write
-= nr_pages
;
2190 if (wbc
->nr_to_write
<= 0)
2196 if (!scanned
&& !done
) {
2198 * We hit the last page and there is more work to be done: wrap
2199 * back to the start of the file
2206 if (wbc
->range_cyclic
|| (range_whole
&& wbc
->nr_to_write
> 0))
2207 mapping
->writeback_index
= index
;
2213 cifs_writepage_locked(struct page
*page
, struct writeback_control
*wbc
)
2219 /* BB add check for wbc flags */
2221 if (!PageUptodate(page
))
2222 cifs_dbg(FYI
, "ppw - page not up to date\n");
2225 * Set the "writeback" flag, and clear "dirty" in the radix tree.
2227 * A writepage() implementation always needs to do either this,
2228 * or re-dirty the page with "redirty_page_for_writepage()" in
2229 * the case of a failure.
2231 * Just unlocking the page will cause the radix tree tag-bits
2232 * to fail to update with the state of the page correctly.
2234 set_page_writeback(page
);
2236 rc
= cifs_partialpagewrite(page
, 0, PAGE_SIZE
);
2237 if (rc
== -EAGAIN
&& wbc
->sync_mode
== WB_SYNC_ALL
)
2239 else if (rc
== -EAGAIN
)
2240 redirty_page_for_writepage(wbc
, page
);
2244 SetPageUptodate(page
);
2245 end_page_writeback(page
);
2251 static int cifs_writepage(struct page
*page
, struct writeback_control
*wbc
)
2253 int rc
= cifs_writepage_locked(page
, wbc
);
2258 static int cifs_write_end(struct file
*file
, struct address_space
*mapping
,
2259 loff_t pos
, unsigned len
, unsigned copied
,
2260 struct page
*page
, void *fsdata
)
2263 struct inode
*inode
= mapping
->host
;
2264 struct cifsFileInfo
*cfile
= file
->private_data
;
2265 struct cifs_sb_info
*cifs_sb
= CIFS_SB(cfile
->dentry
->d_sb
);
2268 if (cifs_sb
->mnt_cifs_flags
& CIFS_MOUNT_RWPIDFORWARD
)
2271 pid
= current
->tgid
;
2273 cifs_dbg(FYI
, "write_end for page %p from pos %lld with %d bytes\n",
2276 if (PageChecked(page
)) {
2278 SetPageUptodate(page
);
2279 ClearPageChecked(page
);
2280 } else if (!PageUptodate(page
) && copied
== PAGE_SIZE
)
2281 SetPageUptodate(page
);
2283 if (!PageUptodate(page
)) {
2285 unsigned offset
= pos
& (PAGE_SIZE
- 1);
2289 /* this is probably better than directly calling
2290 partialpage_write since in this function the file handle is
2291 known which we might as well leverage */
2292 /* BB check if anything else missing out of ppw
2293 such as updating last write time */
2294 page_data
= kmap(page
);
2295 rc
= cifs_write(cfile
, pid
, page_data
+ offset
, copied
, &pos
);
2296 /* if (rc < 0) should we set writebehind rc? */
2303 set_page_dirty(page
);
2307 spin_lock(&inode
->i_lock
);
2308 if (pos
> inode
->i_size
)
2309 i_size_write(inode
, pos
);
2310 spin_unlock(&inode
->i_lock
);
2319 int cifs_strict_fsync(struct file
*file
, loff_t start
, loff_t end
,
2324 struct cifs_tcon
*tcon
;
2325 struct TCP_Server_Info
*server
;
2326 struct cifsFileInfo
*smbfile
= file
->private_data
;
2327 struct inode
*inode
= file_inode(file
);
2328 struct cifs_sb_info
*cifs_sb
= CIFS_SB(inode
->i_sb
);
2330 rc
= filemap_write_and_wait_range(inode
->i_mapping
, start
, end
);
2337 cifs_dbg(FYI
, "Sync file - name: %pD datasync: 0x%x\n",
2340 if (!CIFS_CACHE_READ(CIFS_I(inode
))) {
2341 rc
= cifs_zap_mapping(inode
);
2343 cifs_dbg(FYI
, "rc: %d during invalidate phase\n", rc
);
2344 rc
= 0; /* don't care about it in fsync */
2348 tcon
= tlink_tcon(smbfile
->tlink
);
2349 if (!(cifs_sb
->mnt_cifs_flags
& CIFS_MOUNT_NOSSYNC
)) {
2350 server
= tcon
->ses
->server
;
2351 if (server
->ops
->flush
)
2352 rc
= server
->ops
->flush(xid
, tcon
, &smbfile
->fid
);
2358 inode_unlock(inode
);
2362 int cifs_fsync(struct file
*file
, loff_t start
, loff_t end
, int datasync
)
2366 struct cifs_tcon
*tcon
;
2367 struct TCP_Server_Info
*server
;
2368 struct cifsFileInfo
*smbfile
= file
->private_data
;
2369 struct cifs_sb_info
*cifs_sb
= CIFS_FILE_SB(file
);
2370 struct inode
*inode
= file
->f_mapping
->host
;
2372 rc
= filemap_write_and_wait_range(inode
->i_mapping
, start
, end
);
2379 cifs_dbg(FYI
, "Sync file - name: %pD datasync: 0x%x\n",
2382 tcon
= tlink_tcon(smbfile
->tlink
);
2383 if (!(cifs_sb
->mnt_cifs_flags
& CIFS_MOUNT_NOSSYNC
)) {
2384 server
= tcon
->ses
->server
;
2385 if (server
->ops
->flush
)
2386 rc
= server
->ops
->flush(xid
, tcon
, &smbfile
->fid
);
2392 inode_unlock(inode
);
2397 * As file closes, flush all cached write data for this inode checking
2398 * for write behind errors.
2400 int cifs_flush(struct file
*file
, fl_owner_t id
)
2402 struct inode
*inode
= file_inode(file
);
2405 if (file
->f_mode
& FMODE_WRITE
)
2406 rc
= filemap_write_and_wait(inode
->i_mapping
);
2408 cifs_dbg(FYI
, "Flush inode %p file %p rc %d\n", inode
, file
, rc
);
2414 cifs_write_allocate_pages(struct page
**pages
, unsigned long num_pages
)
2419 for (i
= 0; i
< num_pages
; i
++) {
2420 pages
[i
] = alloc_page(GFP_KERNEL
|__GFP_HIGHMEM
);
2423 * save number of pages we have already allocated and
2424 * return with ENOMEM error
2433 for (i
= 0; i
< num_pages
; i
++)
2440 size_t get_numpages(const size_t wsize
, const size_t len
, size_t *cur_len
)
2445 clen
= min_t(const size_t, len
, wsize
);
2446 num_pages
= DIV_ROUND_UP(clen
, PAGE_SIZE
);
2455 cifs_uncached_writedata_release(struct kref
*refcount
)
2458 struct cifs_writedata
*wdata
= container_of(refcount
,
2459 struct cifs_writedata
, refcount
);
2461 for (i
= 0; i
< wdata
->nr_pages
; i
++)
2462 put_page(wdata
->pages
[i
]);
2463 cifs_writedata_release(refcount
);
2467 cifs_uncached_writev_complete(struct work_struct
*work
)
2469 struct cifs_writedata
*wdata
= container_of(work
,
2470 struct cifs_writedata
, work
);
2471 struct inode
*inode
= d_inode(wdata
->cfile
->dentry
);
2472 struct cifsInodeInfo
*cifsi
= CIFS_I(inode
);
2474 spin_lock(&inode
->i_lock
);
2475 cifs_update_eof(cifsi
, wdata
->offset
, wdata
->bytes
);
2476 if (cifsi
->server_eof
> inode
->i_size
)
2477 i_size_write(inode
, cifsi
->server_eof
);
2478 spin_unlock(&inode
->i_lock
);
2480 complete(&wdata
->done
);
2482 kref_put(&wdata
->refcount
, cifs_uncached_writedata_release
);
2486 wdata_fill_from_iovec(struct cifs_writedata
*wdata
, struct iov_iter
*from
,
2487 size_t *len
, unsigned long *num_pages
)
2489 size_t save_len
, copied
, bytes
, cur_len
= *len
;
2490 unsigned long i
, nr_pages
= *num_pages
;
2493 for (i
= 0; i
< nr_pages
; i
++) {
2494 bytes
= min_t(const size_t, cur_len
, PAGE_SIZE
);
2495 copied
= copy_page_from_iter(wdata
->pages
[i
], 0, bytes
, from
);
2498 * If we didn't copy as much as we expected, then that
2499 * may mean we trod into an unmapped area. Stop copying
2500 * at that point. On the next pass through the big
2501 * loop, we'll likely end up getting a zero-length
2502 * write and bailing out of it.
2507 cur_len
= save_len
- cur_len
;
2511 * If we have no data to send, then that probably means that
2512 * the copy above failed altogether. That's most likely because
2513 * the address in the iovec was bogus. Return -EFAULT and let
2514 * the caller free anything we allocated and bail out.
2520 * i + 1 now represents the number of pages we actually used in
2521 * the copy phase above.
2528 cifs_write_from_iter(loff_t offset
, size_t len
, struct iov_iter
*from
,
2529 struct cifsFileInfo
*open_file
,
2530 struct cifs_sb_info
*cifs_sb
, struct list_head
*wdata_list
)
2534 unsigned long nr_pages
, num_pages
, i
;
2535 struct cifs_writedata
*wdata
;
2536 struct iov_iter saved_from
= *from
;
2537 loff_t saved_offset
= offset
;
2539 struct TCP_Server_Info
*server
;
2541 if (cifs_sb
->mnt_cifs_flags
& CIFS_MOUNT_RWPIDFORWARD
)
2542 pid
= open_file
->pid
;
2544 pid
= current
->tgid
;
2546 server
= tlink_tcon(open_file
->tlink
)->ses
->server
;
2549 unsigned int wsize
, credits
;
2551 rc
= server
->ops
->wait_mtu_credits(server
, cifs_sb
->wsize
,
2556 nr_pages
= get_numpages(wsize
, len
, &cur_len
);
2557 wdata
= cifs_writedata_alloc(nr_pages
,
2558 cifs_uncached_writev_complete
);
2561 add_credits_and_wake_if(server
, credits
, 0);
2565 rc
= cifs_write_allocate_pages(wdata
->pages
, nr_pages
);
2568 add_credits_and_wake_if(server
, credits
, 0);
2572 num_pages
= nr_pages
;
2573 rc
= wdata_fill_from_iovec(wdata
, from
, &cur_len
, &num_pages
);
2575 for (i
= 0; i
< nr_pages
; i
++)
2576 put_page(wdata
->pages
[i
]);
2578 add_credits_and_wake_if(server
, credits
, 0);
2583 * Bring nr_pages down to the number of pages we actually used,
2584 * and free any pages that we didn't use.
2586 for ( ; nr_pages
> num_pages
; nr_pages
--)
2587 put_page(wdata
->pages
[nr_pages
- 1]);
2589 wdata
->sync_mode
= WB_SYNC_ALL
;
2590 wdata
->nr_pages
= nr_pages
;
2591 wdata
->offset
= (__u64
)offset
;
2592 wdata
->cfile
= cifsFileInfo_get(open_file
);
2594 wdata
->bytes
= cur_len
;
2595 wdata
->pagesz
= PAGE_SIZE
;
2596 wdata
->tailsz
= cur_len
- ((nr_pages
- 1) * PAGE_SIZE
);
2597 wdata
->credits
= credits
;
2599 if (!wdata
->cfile
->invalidHandle
||
2600 !(rc
= cifs_reopen_file(wdata
->cfile
, false)))
2601 rc
= server
->ops
->async_writev(wdata
,
2602 cifs_uncached_writedata_release
);
2604 add_credits_and_wake_if(server
, wdata
->credits
, 0);
2605 kref_put(&wdata
->refcount
,
2606 cifs_uncached_writedata_release
);
2607 if (rc
== -EAGAIN
) {
2609 iov_iter_advance(from
, offset
- saved_offset
);
2615 list_add_tail(&wdata
->list
, wdata_list
);
2623 ssize_t
cifs_user_writev(struct kiocb
*iocb
, struct iov_iter
*from
)
2625 struct file
*file
= iocb
->ki_filp
;
2626 ssize_t total_written
= 0;
2627 struct cifsFileInfo
*open_file
;
2628 struct cifs_tcon
*tcon
;
2629 struct cifs_sb_info
*cifs_sb
;
2630 struct cifs_writedata
*wdata
, *tmp
;
2631 struct list_head wdata_list
;
2632 struct iov_iter saved_from
= *from
;
2636 * BB - optimize the way when signing is disabled. We can drop this
2637 * extra memory-to-memory copying and use iovec buffers for constructing
2641 rc
= generic_write_checks(iocb
, from
);
2645 INIT_LIST_HEAD(&wdata_list
);
2646 cifs_sb
= CIFS_FILE_SB(file
);
2647 open_file
= file
->private_data
;
2648 tcon
= tlink_tcon(open_file
->tlink
);
2650 if (!tcon
->ses
->server
->ops
->async_writev
)
2653 rc
= cifs_write_from_iter(iocb
->ki_pos
, iov_iter_count(from
), from
,
2654 open_file
, cifs_sb
, &wdata_list
);
2657 * If at least one write was successfully sent, then discard any rc
2658 * value from the later writes. If the other write succeeds, then
2659 * we'll end up returning whatever was written. If it fails, then
2660 * we'll get a new rc value from that.
2662 if (!list_empty(&wdata_list
))
2666 * Wait for and collect replies for any successful sends in order of
2667 * increasing offset. Once an error is hit or we get a fatal signal
2668 * while waiting, then return without waiting for any more replies.
2671 list_for_each_entry_safe(wdata
, tmp
, &wdata_list
, list
) {
2673 /* FIXME: freezable too? */
2674 rc
= wait_for_completion_killable(&wdata
->done
);
2677 else if (wdata
->result
)
2680 total_written
+= wdata
->bytes
;
2682 /* resend call if it's a retryable error */
2683 if (rc
== -EAGAIN
) {
2684 struct list_head tmp_list
;
2685 struct iov_iter tmp_from
= saved_from
;
2687 INIT_LIST_HEAD(&tmp_list
);
2688 list_del_init(&wdata
->list
);
2690 iov_iter_advance(&tmp_from
,
2691 wdata
->offset
- iocb
->ki_pos
);
2693 rc
= cifs_write_from_iter(wdata
->offset
,
2694 wdata
->bytes
, &tmp_from
,
2695 open_file
, cifs_sb
, &tmp_list
);
2697 list_splice(&tmp_list
, &wdata_list
);
2699 kref_put(&wdata
->refcount
,
2700 cifs_uncached_writedata_release
);
2704 list_del_init(&wdata
->list
);
2705 kref_put(&wdata
->refcount
, cifs_uncached_writedata_release
);
2708 if (unlikely(!total_written
))
2711 iocb
->ki_pos
+= total_written
;
2712 set_bit(CIFS_INO_INVALID_MAPPING
, &CIFS_I(file_inode(file
))->flags
);
2713 cifs_stats_bytes_written(tcon
, total_written
);
2714 return total_written
;
2718 cifs_writev(struct kiocb
*iocb
, struct iov_iter
*from
)
2720 struct file
*file
= iocb
->ki_filp
;
2721 struct cifsFileInfo
*cfile
= (struct cifsFileInfo
*)file
->private_data
;
2722 struct inode
*inode
= file
->f_mapping
->host
;
2723 struct cifsInodeInfo
*cinode
= CIFS_I(inode
);
2724 struct TCP_Server_Info
*server
= tlink_tcon(cfile
->tlink
)->ses
->server
;
2728 * We need to hold the sem to be sure nobody modifies lock list
2729 * with a brlock that prevents writing.
2731 down_read(&cinode
->lock_sem
);
2734 rc
= generic_write_checks(iocb
, from
);
2738 if (!cifs_find_lock_conflict(cfile
, iocb
->ki_pos
, iov_iter_count(from
),
2739 server
->vals
->exclusive_lock_type
, NULL
,
2741 rc
= __generic_file_write_iter(iocb
, from
);
2745 inode_unlock(inode
);
2748 rc
= generic_write_sync(iocb
, rc
);
2749 up_read(&cinode
->lock_sem
);
2754 cifs_strict_writev(struct kiocb
*iocb
, struct iov_iter
*from
)
2756 struct inode
*inode
= file_inode(iocb
->ki_filp
);
2757 struct cifsInodeInfo
*cinode
= CIFS_I(inode
);
2758 struct cifs_sb_info
*cifs_sb
= CIFS_SB(inode
->i_sb
);
2759 struct cifsFileInfo
*cfile
= (struct cifsFileInfo
*)
2760 iocb
->ki_filp
->private_data
;
2761 struct cifs_tcon
*tcon
= tlink_tcon(cfile
->tlink
);
2764 written
= cifs_get_writer(cinode
);
2768 if (CIFS_CACHE_WRITE(cinode
)) {
2769 if (cap_unix(tcon
->ses
) &&
2770 (CIFS_UNIX_FCNTL_CAP
& le64_to_cpu(tcon
->fsUnixInfo
.Capability
))
2771 && ((cifs_sb
->mnt_cifs_flags
& CIFS_MOUNT_NOPOSIXBRL
) == 0)) {
2772 written
= generic_file_write_iter(iocb
, from
);
2775 written
= cifs_writev(iocb
, from
);
2779 * For non-oplocked files in strict cache mode we need to write the data
2780 * to the server exactly from the pos to pos+len-1 rather than flush all
2781 * affected pages because it may cause a error with mandatory locks on
2782 * these pages but not on the region from pos to ppos+len-1.
2784 written
= cifs_user_writev(iocb
, from
);
2785 if (written
> 0 && CIFS_CACHE_READ(cinode
)) {
2787 * Windows 7 server can delay breaking level2 oplock if a write
2788 * request comes - break it on the client to prevent reading
2791 cifs_zap_mapping(inode
);
2792 cifs_dbg(FYI
, "Set no oplock for inode=%p after a write operation\n",
2797 cifs_put_writer(cinode
);
2801 static struct cifs_readdata
*
2802 cifs_readdata_alloc(unsigned int nr_pages
, work_func_t complete
)
2804 struct cifs_readdata
*rdata
;
2806 rdata
= kzalloc(sizeof(*rdata
) + (sizeof(struct page
*) * nr_pages
),
2808 if (rdata
!= NULL
) {
2809 kref_init(&rdata
->refcount
);
2810 INIT_LIST_HEAD(&rdata
->list
);
2811 init_completion(&rdata
->done
);
2812 INIT_WORK(&rdata
->work
, complete
);
2819 cifs_readdata_release(struct kref
*refcount
)
2821 struct cifs_readdata
*rdata
= container_of(refcount
,
2822 struct cifs_readdata
, refcount
);
2825 cifsFileInfo_put(rdata
->cfile
);
2831 cifs_read_allocate_pages(struct cifs_readdata
*rdata
, unsigned int nr_pages
)
2837 for (i
= 0; i
< nr_pages
; i
++) {
2838 page
= alloc_page(GFP_KERNEL
|__GFP_HIGHMEM
);
2843 rdata
->pages
[i
] = page
;
2847 for (i
= 0; i
< nr_pages
; i
++) {
2848 put_page(rdata
->pages
[i
]);
2849 rdata
->pages
[i
] = NULL
;
2856 cifs_uncached_readdata_release(struct kref
*refcount
)
2858 struct cifs_readdata
*rdata
= container_of(refcount
,
2859 struct cifs_readdata
, refcount
);
2862 for (i
= 0; i
< rdata
->nr_pages
; i
++) {
2863 put_page(rdata
->pages
[i
]);
2864 rdata
->pages
[i
] = NULL
;
2866 cifs_readdata_release(refcount
);
2870 * cifs_readdata_to_iov - copy data from pages in response to an iovec
2871 * @rdata: the readdata response with list of pages holding data
2872 * @iter: destination for our data
2874 * This function copies data from a list of pages in a readdata response into
2875 * an array of iovecs. It will first calculate where the data should go
2876 * based on the info in the readdata and then copy the data into that spot.
2879 cifs_readdata_to_iov(struct cifs_readdata
*rdata
, struct iov_iter
*iter
)
2881 size_t remaining
= rdata
->got_bytes
;
2884 for (i
= 0; i
< rdata
->nr_pages
; i
++) {
2885 struct page
*page
= rdata
->pages
[i
];
2886 size_t copy
= min_t(size_t, remaining
, PAGE_SIZE
);
2889 if (unlikely(iter
->type
& ITER_PIPE
)) {
2890 void *addr
= kmap_atomic(page
);
2892 written
= copy_to_iter(addr
, copy
, iter
);
2893 kunmap_atomic(addr
);
2895 written
= copy_page_to_iter(page
, 0, copy
, iter
);
2896 remaining
-= written
;
2897 if (written
< copy
&& iov_iter_count(iter
) > 0)
2900 return remaining
? -EFAULT
: 0;
2904 cifs_uncached_readv_complete(struct work_struct
*work
)
2906 struct cifs_readdata
*rdata
= container_of(work
,
2907 struct cifs_readdata
, work
);
2909 complete(&rdata
->done
);
2910 kref_put(&rdata
->refcount
, cifs_uncached_readdata_release
);
2914 uncached_fill_pages(struct TCP_Server_Info
*server
,
2915 struct cifs_readdata
*rdata
, struct iov_iter
*iter
,
2920 unsigned int nr_pages
= rdata
->nr_pages
;
2922 rdata
->got_bytes
= 0;
2923 rdata
->tailsz
= PAGE_SIZE
;
2924 for (i
= 0; i
< nr_pages
; i
++) {
2925 struct page
*page
= rdata
->pages
[i
];
2929 /* no need to hold page hostage */
2930 rdata
->pages
[i
] = NULL
;
2936 if (len
>= PAGE_SIZE
) {
2937 /* enough data to fill the page */
2941 zero_user(page
, len
, PAGE_SIZE
- len
);
2942 rdata
->tailsz
= len
;
2946 result
= copy_page_from_iter(page
, 0, n
, iter
);
2948 result
= cifs_read_page_from_socket(server
, page
, n
);
2952 rdata
->got_bytes
+= result
;
2955 return rdata
->got_bytes
> 0 && result
!= -ECONNABORTED
?
2956 rdata
->got_bytes
: result
;
2960 cifs_uncached_read_into_pages(struct TCP_Server_Info
*server
,
2961 struct cifs_readdata
*rdata
, unsigned int len
)
2963 return uncached_fill_pages(server
, rdata
, NULL
, len
);
2967 cifs_uncached_copy_into_pages(struct TCP_Server_Info
*server
,
2968 struct cifs_readdata
*rdata
,
2969 struct iov_iter
*iter
)
2971 return uncached_fill_pages(server
, rdata
, iter
, iter
->count
);
2975 cifs_send_async_read(loff_t offset
, size_t len
, struct cifsFileInfo
*open_file
,
2976 struct cifs_sb_info
*cifs_sb
, struct list_head
*rdata_list
)
2978 struct cifs_readdata
*rdata
;
2979 unsigned int npages
, rsize
, credits
;
2983 struct TCP_Server_Info
*server
;
2985 server
= tlink_tcon(open_file
->tlink
)->ses
->server
;
2987 if (cifs_sb
->mnt_cifs_flags
& CIFS_MOUNT_RWPIDFORWARD
)
2988 pid
= open_file
->pid
;
2990 pid
= current
->tgid
;
2993 rc
= server
->ops
->wait_mtu_credits(server
, cifs_sb
->rsize
,
2998 cur_len
= min_t(const size_t, len
, rsize
);
2999 npages
= DIV_ROUND_UP(cur_len
, PAGE_SIZE
);
3001 /* allocate a readdata struct */
3002 rdata
= cifs_readdata_alloc(npages
,
3003 cifs_uncached_readv_complete
);
3005 add_credits_and_wake_if(server
, credits
, 0);
3010 rc
= cifs_read_allocate_pages(rdata
, npages
);
3014 rdata
->cfile
= cifsFileInfo_get(open_file
);
3015 rdata
->nr_pages
= npages
;
3016 rdata
->offset
= offset
;
3017 rdata
->bytes
= cur_len
;
3019 rdata
->pagesz
= PAGE_SIZE
;
3020 rdata
->read_into_pages
= cifs_uncached_read_into_pages
;
3021 rdata
->copy_into_pages
= cifs_uncached_copy_into_pages
;
3022 rdata
->credits
= credits
;
3024 if (!rdata
->cfile
->invalidHandle
||
3025 !(rc
= cifs_reopen_file(rdata
->cfile
, true)))
3026 rc
= server
->ops
->async_readv(rdata
);
3029 add_credits_and_wake_if(server
, rdata
->credits
, 0);
3030 kref_put(&rdata
->refcount
,
3031 cifs_uncached_readdata_release
);
3037 list_add_tail(&rdata
->list
, rdata_list
);
3045 ssize_t
cifs_user_readv(struct kiocb
*iocb
, struct iov_iter
*to
)
3047 struct file
*file
= iocb
->ki_filp
;
3050 ssize_t total_read
= 0;
3051 loff_t offset
= iocb
->ki_pos
;
3052 struct cifs_sb_info
*cifs_sb
;
3053 struct cifs_tcon
*tcon
;
3054 struct cifsFileInfo
*open_file
;
3055 struct cifs_readdata
*rdata
, *tmp
;
3056 struct list_head rdata_list
;
3058 len
= iov_iter_count(to
);
3062 INIT_LIST_HEAD(&rdata_list
);
3063 cifs_sb
= CIFS_FILE_SB(file
);
3064 open_file
= file
->private_data
;
3065 tcon
= tlink_tcon(open_file
->tlink
);
3067 if (!tcon
->ses
->server
->ops
->async_readv
)
3070 if ((file
->f_flags
& O_ACCMODE
) == O_WRONLY
)
3071 cifs_dbg(FYI
, "attempting read on write only file instance\n");
3073 rc
= cifs_send_async_read(offset
, len
, open_file
, cifs_sb
, &rdata_list
);
3075 /* if at least one read request send succeeded, then reset rc */
3076 if (!list_empty(&rdata_list
))
3079 len
= iov_iter_count(to
);
3080 /* the loop below should proceed in the order of increasing offsets */
3082 list_for_each_entry_safe(rdata
, tmp
, &rdata_list
, list
) {
3084 /* FIXME: freezable sleep too? */
3085 rc
= wait_for_completion_killable(&rdata
->done
);
3088 else if (rdata
->result
== -EAGAIN
) {
3089 /* resend call if it's a retryable error */
3090 struct list_head tmp_list
;
3091 unsigned int got_bytes
= rdata
->got_bytes
;
3093 list_del_init(&rdata
->list
);
3094 INIT_LIST_HEAD(&tmp_list
);
3097 * Got a part of data and then reconnect has
3098 * happened -- fill the buffer and continue
3101 if (got_bytes
&& got_bytes
< rdata
->bytes
) {
3102 rc
= cifs_readdata_to_iov(rdata
, to
);
3104 kref_put(&rdata
->refcount
,
3105 cifs_uncached_readdata_release
);
3110 rc
= cifs_send_async_read(
3111 rdata
->offset
+ got_bytes
,
3112 rdata
->bytes
- got_bytes
,
3113 rdata
->cfile
, cifs_sb
,
3116 list_splice(&tmp_list
, &rdata_list
);
3118 kref_put(&rdata
->refcount
,
3119 cifs_uncached_readdata_release
);
3121 } else if (rdata
->result
)
3124 rc
= cifs_readdata_to_iov(rdata
, to
);
3126 /* if there was a short read -- discard anything left */
3127 if (rdata
->got_bytes
&& rdata
->got_bytes
< rdata
->bytes
)
3130 list_del_init(&rdata
->list
);
3131 kref_put(&rdata
->refcount
, cifs_uncached_readdata_release
);
3134 total_read
= len
- iov_iter_count(to
);
3136 cifs_stats_bytes_read(tcon
, total_read
);
3138 /* mask nodata case */
3143 iocb
->ki_pos
+= total_read
;
3150 cifs_strict_readv(struct kiocb
*iocb
, struct iov_iter
*to
)
3152 struct inode
*inode
= file_inode(iocb
->ki_filp
);
3153 struct cifsInodeInfo
*cinode
= CIFS_I(inode
);
3154 struct cifs_sb_info
*cifs_sb
= CIFS_SB(inode
->i_sb
);
3155 struct cifsFileInfo
*cfile
= (struct cifsFileInfo
*)
3156 iocb
->ki_filp
->private_data
;
3157 struct cifs_tcon
*tcon
= tlink_tcon(cfile
->tlink
);
3161 * In strict cache mode we need to read from the server all the time
3162 * if we don't have level II oplock because the server can delay mtime
3163 * change - so we can't make a decision about inode invalidating.
3164 * And we can also fail with pagereading if there are mandatory locks
3165 * on pages affected by this read but not on the region from pos to
3168 if (!CIFS_CACHE_READ(cinode
))
3169 return cifs_user_readv(iocb
, to
);
3171 if (cap_unix(tcon
->ses
) &&
3172 (CIFS_UNIX_FCNTL_CAP
& le64_to_cpu(tcon
->fsUnixInfo
.Capability
)) &&
3173 ((cifs_sb
->mnt_cifs_flags
& CIFS_MOUNT_NOPOSIXBRL
) == 0))
3174 return generic_file_read_iter(iocb
, to
);
3177 * We need to hold the sem to be sure nobody modifies lock list
3178 * with a brlock that prevents reading.
3180 down_read(&cinode
->lock_sem
);
3181 if (!cifs_find_lock_conflict(cfile
, iocb
->ki_pos
, iov_iter_count(to
),
3182 tcon
->ses
->server
->vals
->shared_lock_type
,
3183 NULL
, CIFS_READ_OP
))
3184 rc
= generic_file_read_iter(iocb
, to
);
3185 up_read(&cinode
->lock_sem
);
3190 cifs_read(struct file
*file
, char *read_data
, size_t read_size
, loff_t
*offset
)
3193 unsigned int bytes_read
= 0;
3194 unsigned int total_read
;
3195 unsigned int current_read_size
;
3197 struct cifs_sb_info
*cifs_sb
;
3198 struct cifs_tcon
*tcon
;
3199 struct TCP_Server_Info
*server
;
3202 struct cifsFileInfo
*open_file
;
3203 struct cifs_io_parms io_parms
;
3204 int buf_type
= CIFS_NO_BUFFER
;
3208 cifs_sb
= CIFS_FILE_SB(file
);
3210 /* FIXME: set up handlers for larger reads and/or convert to async */
3211 rsize
= min_t(unsigned int, cifs_sb
->rsize
, CIFSMaxBufSize
);
3213 if (file
->private_data
== NULL
) {
3218 open_file
= file
->private_data
;
3219 tcon
= tlink_tcon(open_file
->tlink
);
3220 server
= tcon
->ses
->server
;
3222 if (!server
->ops
->sync_read
) {
3227 if (cifs_sb
->mnt_cifs_flags
& CIFS_MOUNT_RWPIDFORWARD
)
3228 pid
= open_file
->pid
;
3230 pid
= current
->tgid
;
3232 if ((file
->f_flags
& O_ACCMODE
) == O_WRONLY
)
3233 cifs_dbg(FYI
, "attempting read on write only file instance\n");
3235 for (total_read
= 0, cur_offset
= read_data
; read_size
> total_read
;
3236 total_read
+= bytes_read
, cur_offset
+= bytes_read
) {
3238 current_read_size
= min_t(uint
, read_size
- total_read
,
3241 * For windows me and 9x we do not want to request more
3242 * than it negotiated since it will refuse the read
3245 if ((tcon
->ses
) && !(tcon
->ses
->capabilities
&
3246 tcon
->ses
->server
->vals
->cap_large_files
)) {
3247 current_read_size
= min_t(uint
,
3248 current_read_size
, CIFSMaxBufSize
);
3250 if (open_file
->invalidHandle
) {
3251 rc
= cifs_reopen_file(open_file
, true);
3256 io_parms
.tcon
= tcon
;
3257 io_parms
.offset
= *offset
;
3258 io_parms
.length
= current_read_size
;
3259 rc
= server
->ops
->sync_read(xid
, &open_file
->fid
, &io_parms
,
3260 &bytes_read
, &cur_offset
,
3262 } while (rc
== -EAGAIN
);
3264 if (rc
|| (bytes_read
== 0)) {
3272 cifs_stats_bytes_read(tcon
, total_read
);
3273 *offset
+= bytes_read
;
3281 * If the page is mmap'ed into a process' page tables, then we need to make
3282 * sure that it doesn't change while being written back.
3285 cifs_page_mkwrite(struct vm_fault
*vmf
)
3287 struct page
*page
= vmf
->page
;
3290 return VM_FAULT_LOCKED
;
3293 static const struct vm_operations_struct cifs_file_vm_ops
= {
3294 .fault
= filemap_fault
,
3295 .map_pages
= filemap_map_pages
,
3296 .page_mkwrite
= cifs_page_mkwrite
,
3299 int cifs_file_strict_mmap(struct file
*file
, struct vm_area_struct
*vma
)
3302 struct inode
*inode
= file_inode(file
);
3306 if (!CIFS_CACHE_READ(CIFS_I(inode
))) {
3307 rc
= cifs_zap_mapping(inode
);
3312 rc
= generic_file_mmap(file
, vma
);
3314 vma
->vm_ops
= &cifs_file_vm_ops
;
3319 int cifs_file_mmap(struct file
*file
, struct vm_area_struct
*vma
)
3324 rc
= cifs_revalidate_file(file
);
3326 cifs_dbg(FYI
, "Validation prior to mmap failed, error=%d\n",
3331 rc
= generic_file_mmap(file
, vma
);
3333 vma
->vm_ops
= &cifs_file_vm_ops
;
3339 cifs_readv_complete(struct work_struct
*work
)
3341 unsigned int i
, got_bytes
;
3342 struct cifs_readdata
*rdata
= container_of(work
,
3343 struct cifs_readdata
, work
);
3345 got_bytes
= rdata
->got_bytes
;
3346 for (i
= 0; i
< rdata
->nr_pages
; i
++) {
3347 struct page
*page
= rdata
->pages
[i
];
3349 lru_cache_add_file(page
);
3351 if (rdata
->result
== 0 ||
3352 (rdata
->result
== -EAGAIN
&& got_bytes
)) {
3353 flush_dcache_page(page
);
3354 SetPageUptodate(page
);
3359 if (rdata
->result
== 0 ||
3360 (rdata
->result
== -EAGAIN
&& got_bytes
))
3361 cifs_readpage_to_fscache(rdata
->mapping
->host
, page
);
3363 got_bytes
-= min_t(unsigned int, PAGE_SIZE
, got_bytes
);
3366 rdata
->pages
[i
] = NULL
;
3368 kref_put(&rdata
->refcount
, cifs_readdata_release
);
3372 readpages_fill_pages(struct TCP_Server_Info
*server
,
3373 struct cifs_readdata
*rdata
, struct iov_iter
*iter
,
3380 unsigned int nr_pages
= rdata
->nr_pages
;
3382 /* determine the eof that the server (probably) has */
3383 eof
= CIFS_I(rdata
->mapping
->host
)->server_eof
;
3384 eof_index
= eof
? (eof
- 1) >> PAGE_SHIFT
: 0;
3385 cifs_dbg(FYI
, "eof=%llu eof_index=%lu\n", eof
, eof_index
);
3387 rdata
->got_bytes
= 0;
3388 rdata
->tailsz
= PAGE_SIZE
;
3389 for (i
= 0; i
< nr_pages
; i
++) {
3390 struct page
*page
= rdata
->pages
[i
];
3391 size_t n
= PAGE_SIZE
;
3393 if (len
>= PAGE_SIZE
) {
3395 } else if (len
> 0) {
3396 /* enough for partial page, fill and zero the rest */
3397 zero_user(page
, len
, PAGE_SIZE
- len
);
3398 n
= rdata
->tailsz
= len
;
3400 } else if (page
->index
> eof_index
) {
3402 * The VFS will not try to do readahead past the
3403 * i_size, but it's possible that we have outstanding
3404 * writes with gaps in the middle and the i_size hasn't
3405 * caught up yet. Populate those with zeroed out pages
3406 * to prevent the VFS from repeatedly attempting to
3407 * fill them until the writes are flushed.
3409 zero_user(page
, 0, PAGE_SIZE
);
3410 lru_cache_add_file(page
);
3411 flush_dcache_page(page
);
3412 SetPageUptodate(page
);
3415 rdata
->pages
[i
] = NULL
;
3419 /* no need to hold page hostage */
3420 lru_cache_add_file(page
);
3423 rdata
->pages
[i
] = NULL
;
3429 result
= copy_page_from_iter(page
, 0, n
, iter
);
3431 result
= cifs_read_page_from_socket(server
, page
, n
);
3435 rdata
->got_bytes
+= result
;
3438 return rdata
->got_bytes
> 0 && result
!= -ECONNABORTED
?
3439 rdata
->got_bytes
: result
;
3443 cifs_readpages_read_into_pages(struct TCP_Server_Info
*server
,
3444 struct cifs_readdata
*rdata
, unsigned int len
)
3446 return readpages_fill_pages(server
, rdata
, NULL
, len
);
3450 cifs_readpages_copy_into_pages(struct TCP_Server_Info
*server
,
3451 struct cifs_readdata
*rdata
,
3452 struct iov_iter
*iter
)
3454 return readpages_fill_pages(server
, rdata
, iter
, iter
->count
);
3458 readpages_get_pages(struct address_space
*mapping
, struct list_head
*page_list
,
3459 unsigned int rsize
, struct list_head
*tmplist
,
3460 unsigned int *nr_pages
, loff_t
*offset
, unsigned int *bytes
)
3462 struct page
*page
, *tpage
;
3463 unsigned int expected_index
;
3465 gfp_t gfp
= readahead_gfp_mask(mapping
);
3467 INIT_LIST_HEAD(tmplist
);
3469 page
= list_entry(page_list
->prev
, struct page
, lru
);
3472 * Lock the page and put it in the cache. Since no one else
3473 * should have access to this page, we're safe to simply set
3474 * PG_locked without checking it first.
3476 __SetPageLocked(page
);
3477 rc
= add_to_page_cache_locked(page
, mapping
,
3480 /* give up if we can't stick it in the cache */
3482 __ClearPageLocked(page
);
3486 /* move first page to the tmplist */
3487 *offset
= (loff_t
)page
->index
<< PAGE_SHIFT
;
3490 list_move_tail(&page
->lru
, tmplist
);
3492 /* now try and add more pages onto the request */
3493 expected_index
= page
->index
+ 1;
3494 list_for_each_entry_safe_reverse(page
, tpage
, page_list
, lru
) {
3495 /* discontinuity ? */
3496 if (page
->index
!= expected_index
)
3499 /* would this page push the read over the rsize? */
3500 if (*bytes
+ PAGE_SIZE
> rsize
)
3503 __SetPageLocked(page
);
3504 if (add_to_page_cache_locked(page
, mapping
, page
->index
, gfp
)) {
3505 __ClearPageLocked(page
);
3508 list_move_tail(&page
->lru
, tmplist
);
3509 (*bytes
) += PAGE_SIZE
;
3516 static int cifs_readpages(struct file
*file
, struct address_space
*mapping
,
3517 struct list_head
*page_list
, unsigned num_pages
)
3520 struct list_head tmplist
;
3521 struct cifsFileInfo
*open_file
= file
->private_data
;
3522 struct cifs_sb_info
*cifs_sb
= CIFS_FILE_SB(file
);
3523 struct TCP_Server_Info
*server
;
3527 * Reads as many pages as possible from fscache. Returns -ENOBUFS
3528 * immediately if the cookie is negative
3530 * After this point, every page in the list might have PG_fscache set,
3531 * so we will need to clean that up off of every page we don't use.
3533 rc
= cifs_readpages_from_fscache(mapping
->host
, mapping
, page_list
,
3538 if (cifs_sb
->mnt_cifs_flags
& CIFS_MOUNT_RWPIDFORWARD
)
3539 pid
= open_file
->pid
;
3541 pid
= current
->tgid
;
3544 server
= tlink_tcon(open_file
->tlink
)->ses
->server
;
3546 cifs_dbg(FYI
, "%s: file=%p mapping=%p num_pages=%u\n",
3547 __func__
, file
, mapping
, num_pages
);
3550 * Start with the page at end of list and move it to private
3551 * list. Do the same with any following pages until we hit
3552 * the rsize limit, hit an index discontinuity, or run out of
3553 * pages. Issue the async read and then start the loop again
3554 * until the list is empty.
3556 * Note that list order is important. The page_list is in
3557 * the order of declining indexes. When we put the pages in
3558 * the rdata->pages, then we want them in increasing order.
3560 while (!list_empty(page_list
)) {
3561 unsigned int i
, nr_pages
, bytes
, rsize
;
3563 struct page
*page
, *tpage
;
3564 struct cifs_readdata
*rdata
;
3567 rc
= server
->ops
->wait_mtu_credits(server
, cifs_sb
->rsize
,
3573 * Give up immediately if rsize is too small to read an entire
3574 * page. The VFS will fall back to readpage. We should never
3575 * reach this point however since we set ra_pages to 0 when the
3576 * rsize is smaller than a cache page.
3578 if (unlikely(rsize
< PAGE_SIZE
)) {
3579 add_credits_and_wake_if(server
, credits
, 0);
3583 rc
= readpages_get_pages(mapping
, page_list
, rsize
, &tmplist
,
3584 &nr_pages
, &offset
, &bytes
);
3586 add_credits_and_wake_if(server
, credits
, 0);
3590 rdata
= cifs_readdata_alloc(nr_pages
, cifs_readv_complete
);
3592 /* best to give up if we're out of mem */
3593 list_for_each_entry_safe(page
, tpage
, &tmplist
, lru
) {
3594 list_del(&page
->lru
);
3595 lru_cache_add_file(page
);
3600 add_credits_and_wake_if(server
, credits
, 0);
3604 rdata
->cfile
= cifsFileInfo_get(open_file
);
3605 rdata
->mapping
= mapping
;
3606 rdata
->offset
= offset
;
3607 rdata
->bytes
= bytes
;
3609 rdata
->pagesz
= PAGE_SIZE
;
3610 rdata
->read_into_pages
= cifs_readpages_read_into_pages
;
3611 rdata
->copy_into_pages
= cifs_readpages_copy_into_pages
;
3612 rdata
->credits
= credits
;
3614 list_for_each_entry_safe(page
, tpage
, &tmplist
, lru
) {
3615 list_del(&page
->lru
);
3616 rdata
->pages
[rdata
->nr_pages
++] = page
;
3619 if (!rdata
->cfile
->invalidHandle
||
3620 !(rc
= cifs_reopen_file(rdata
->cfile
, true)))
3621 rc
= server
->ops
->async_readv(rdata
);
3623 add_credits_and_wake_if(server
, rdata
->credits
, 0);
3624 for (i
= 0; i
< rdata
->nr_pages
; i
++) {
3625 page
= rdata
->pages
[i
];
3626 lru_cache_add_file(page
);
3630 /* Fallback to the readpage in error/reconnect cases */
3631 kref_put(&rdata
->refcount
, cifs_readdata_release
);
3635 kref_put(&rdata
->refcount
, cifs_readdata_release
);
3638 /* Any pages that have been shown to fscache but didn't get added to
3639 * the pagecache must be uncached before they get returned to the
3642 cifs_fscache_readpages_cancel(mapping
->host
, page_list
);
3647 * cifs_readpage_worker must be called with the page pinned
3649 static int cifs_readpage_worker(struct file
*file
, struct page
*page
,
3655 /* Is the page cached? */
3656 rc
= cifs_readpage_from_fscache(file_inode(file
), page
);
3660 read_data
= kmap(page
);
3661 /* for reads over a certain size could initiate async read ahead */
3663 rc
= cifs_read(file
, read_data
, PAGE_SIZE
, poffset
);
3668 cifs_dbg(FYI
, "Bytes read %d\n", rc
);
3670 file_inode(file
)->i_atime
=
3671 current_time(file_inode(file
));
3674 memset(read_data
+ rc
, 0, PAGE_SIZE
- rc
);
3676 flush_dcache_page(page
);
3677 SetPageUptodate(page
);
3679 /* send this page to the cache */
3680 cifs_readpage_to_fscache(file_inode(file
), page
);
3692 static int cifs_readpage(struct file
*file
, struct page
*page
)
3694 loff_t offset
= (loff_t
)page
->index
<< PAGE_SHIFT
;
3700 if (file
->private_data
== NULL
) {
3706 cifs_dbg(FYI
, "readpage %p at offset %d 0x%x\n",
3707 page
, (int)offset
, (int)offset
);
3709 rc
= cifs_readpage_worker(file
, page
, &offset
);
3715 static int is_inode_writable(struct cifsInodeInfo
*cifs_inode
)
3717 struct cifsFileInfo
*open_file
;
3718 struct cifs_tcon
*tcon
=
3719 cifs_sb_master_tcon(CIFS_SB(cifs_inode
->vfs_inode
.i_sb
));
3721 spin_lock(&tcon
->open_file_lock
);
3722 list_for_each_entry(open_file
, &cifs_inode
->openFileList
, flist
) {
3723 if (OPEN_FMODE(open_file
->f_flags
) & FMODE_WRITE
) {
3724 spin_unlock(&tcon
->open_file_lock
);
3728 spin_unlock(&tcon
->open_file_lock
);
3732 /* We do not want to update the file size from server for inodes
3733 open for write - to avoid races with writepage extending
3734 the file - in the future we could consider allowing
3735 refreshing the inode only on increases in the file size
3736 but this is tricky to do without racing with writebehind
3737 page caching in the current Linux kernel design */
3738 bool is_size_safe_to_change(struct cifsInodeInfo
*cifsInode
, __u64 end_of_file
)
3743 if (is_inode_writable(cifsInode
)) {
3744 /* This inode is open for write at least once */
3745 struct cifs_sb_info
*cifs_sb
;
3747 cifs_sb
= CIFS_SB(cifsInode
->vfs_inode
.i_sb
);
3748 if (cifs_sb
->mnt_cifs_flags
& CIFS_MOUNT_DIRECT_IO
) {
3749 /* since no page cache to corrupt on directio
3750 we can change size safely */
3754 if (i_size_read(&cifsInode
->vfs_inode
) < end_of_file
)
3762 static int cifs_write_begin(struct file
*file
, struct address_space
*mapping
,
3763 loff_t pos
, unsigned len
, unsigned flags
,
3764 struct page
**pagep
, void **fsdata
)
3767 pgoff_t index
= pos
>> PAGE_SHIFT
;
3768 loff_t offset
= pos
& (PAGE_SIZE
- 1);
3769 loff_t page_start
= pos
& PAGE_MASK
;
3774 cifs_dbg(FYI
, "write_begin from %lld len %d\n", (long long)pos
, len
);
3777 page
= grab_cache_page_write_begin(mapping
, index
, flags
);
3783 if (PageUptodate(page
))
3787 * If we write a full page it will be up to date, no need to read from
3788 * the server. If the write is short, we'll end up doing a sync write
3791 if (len
== PAGE_SIZE
)
3795 * optimize away the read when we have an oplock, and we're not
3796 * expecting to use any of the data we'd be reading in. That
3797 * is, when the page lies beyond the EOF, or straddles the EOF
3798 * and the write will cover all of the existing data.
3800 if (CIFS_CACHE_READ(CIFS_I(mapping
->host
))) {
3801 i_size
= i_size_read(mapping
->host
);
3802 if (page_start
>= i_size
||
3803 (offset
== 0 && (pos
+ len
) >= i_size
)) {
3804 zero_user_segments(page
, 0, offset
,
3808 * PageChecked means that the parts of the page
3809 * to which we're not writing are considered up
3810 * to date. Once the data is copied to the
3811 * page, it can be set uptodate.
3813 SetPageChecked(page
);
3818 if ((file
->f_flags
& O_ACCMODE
) != O_WRONLY
&& !oncethru
) {
3820 * might as well read a page, it is fast enough. If we get
3821 * an error, we don't need to return it. cifs_write_end will
3822 * do a sync write instead since PG_uptodate isn't set.
3824 cifs_readpage_worker(file
, page
, &page_start
);
3829 /* we could try using another file handle if there is one -
3830 but how would we lock it to prevent close of that handle
3831 racing with this read? In any case
3832 this will be written out by write_end so is fine */
3839 static int cifs_release_page(struct page
*page
, gfp_t gfp
)
3841 if (PagePrivate(page
))
3844 return cifs_fscache_release_page(page
, gfp
);
3847 static void cifs_invalidate_page(struct page
*page
, unsigned int offset
,
3848 unsigned int length
)
3850 struct cifsInodeInfo
*cifsi
= CIFS_I(page
->mapping
->host
);
3852 if (offset
== 0 && length
== PAGE_SIZE
)
3853 cifs_fscache_invalidate_page(page
, &cifsi
->vfs_inode
);
3856 static int cifs_launder_page(struct page
*page
)
3859 loff_t range_start
= page_offset(page
);
3860 loff_t range_end
= range_start
+ (loff_t
)(PAGE_SIZE
- 1);
3861 struct writeback_control wbc
= {
3862 .sync_mode
= WB_SYNC_ALL
,
3864 .range_start
= range_start
,
3865 .range_end
= range_end
,
3868 cifs_dbg(FYI
, "Launder page: %p\n", page
);
3870 if (clear_page_dirty_for_io(page
))
3871 rc
= cifs_writepage_locked(page
, &wbc
);
3873 cifs_fscache_invalidate_page(page
, page
->mapping
->host
);
3877 void cifs_oplock_break(struct work_struct
*work
)
3879 struct cifsFileInfo
*cfile
= container_of(work
, struct cifsFileInfo
,
3881 struct inode
*inode
= d_inode(cfile
->dentry
);
3882 struct cifsInodeInfo
*cinode
= CIFS_I(inode
);
3883 struct cifs_tcon
*tcon
= tlink_tcon(cfile
->tlink
);
3884 struct TCP_Server_Info
*server
= tcon
->ses
->server
;
3887 wait_on_bit(&cinode
->flags
, CIFS_INODE_PENDING_WRITERS
,
3888 TASK_UNINTERRUPTIBLE
);
3890 server
->ops
->downgrade_oplock(server
, cinode
,
3891 test_bit(CIFS_INODE_DOWNGRADE_OPLOCK_TO_L2
, &cinode
->flags
));
3893 if (!CIFS_CACHE_WRITE(cinode
) && CIFS_CACHE_READ(cinode
) &&
3894 cifs_has_mand_locks(cinode
)) {
3895 cifs_dbg(FYI
, "Reset oplock to None for inode=%p due to mand locks\n",
3900 if (inode
&& S_ISREG(inode
->i_mode
)) {
3901 if (CIFS_CACHE_READ(cinode
))
3902 break_lease(inode
, O_RDONLY
);
3904 break_lease(inode
, O_WRONLY
);
3905 rc
= filemap_fdatawrite(inode
->i_mapping
);
3906 if (!CIFS_CACHE_READ(cinode
)) {
3907 rc
= filemap_fdatawait(inode
->i_mapping
);
3908 mapping_set_error(inode
->i_mapping
, rc
);
3909 cifs_zap_mapping(inode
);
3911 cifs_dbg(FYI
, "Oplock flush inode %p rc %d\n", inode
, rc
);
3914 rc
= cifs_push_locks(cfile
);
3916 cifs_dbg(VFS
, "Push locks rc = %d\n", rc
);
3919 * releasing stale oplock after recent reconnect of smb session using
3920 * a now incorrect file handle is not a data integrity issue but do
3921 * not bother sending an oplock release if session to server still is
3922 * disconnected since oplock already released by the server
3924 if (!cfile
->oplock_break_cancelled
) {
3925 rc
= tcon
->ses
->server
->ops
->oplock_response(tcon
, &cfile
->fid
,
3927 cifs_dbg(FYI
, "Oplock release rc = %d\n", rc
);
3929 cifs_done_oplock_break(cinode
);
3933 * The presence of cifs_direct_io() in the address space ops vector
3934 * allowes open() O_DIRECT flags which would have failed otherwise.
3936 * In the non-cached mode (mount with cache=none), we shunt off direct read and write requests
3937 * so this method should never be called.
3939 * Direct IO is not yet supported in the cached mode.
3942 cifs_direct_io(struct kiocb
*iocb
, struct iov_iter
*iter
)
3946 * Eventually need to support direct IO for non forcedirectio mounts
3952 const struct address_space_operations cifs_addr_ops
= {
3953 .readpage
= cifs_readpage
,
3954 .readpages
= cifs_readpages
,
3955 .writepage
= cifs_writepage
,
3956 .writepages
= cifs_writepages
,
3957 .write_begin
= cifs_write_begin
,
3958 .write_end
= cifs_write_end
,
3959 .set_page_dirty
= __set_page_dirty_nobuffers
,
3960 .releasepage
= cifs_release_page
,
3961 .direct_IO
= cifs_direct_io
,
3962 .invalidatepage
= cifs_invalidate_page
,
3963 .launder_page
= cifs_launder_page
,
3967 * cifs_readpages requires the server to support a buffer large enough to
3968 * contain the header plus one complete page of data. Otherwise, we need
3969 * to leave cifs_readpages out of the address space operations.
3971 const struct address_space_operations cifs_addr_ops_smallbuf
= {
3972 .readpage
= cifs_readpage
,
3973 .writepage
= cifs_writepage
,
3974 .writepages
= cifs_writepages
,
3975 .write_begin
= cifs_write_begin
,
3976 .write_end
= cifs_write_end
,
3977 .set_page_dirty
= __set_page_dirty_nobuffers
,
3978 .releasepage
= cifs_release_page
,
3979 .invalidatepage
= cifs_invalidate_page
,
3980 .launder_page
= cifs_launder_page
,