file.c 59.4 KB
Newer Older
L
Linus Torvalds 已提交
1 2 3 4
/*
 *   fs/cifs/file.c
 *
 *   vfs operations that deal with files
S
Steve French 已提交
5
 *
6
 *   Copyright (C) International Business Machines  Corp., 2002,2010
L
Linus Torvalds 已提交
7
 *   Author(s): Steve French (sfrench@us.ibm.com)
J
[CIFS]  
Jeremy Allison 已提交
8
 *              Jeremy Allison (jra@samba.org)
L
Linus Torvalds 已提交
9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24
 *
 *   This library is free software; you can redistribute it and/or modify
 *   it under the terms of the GNU Lesser General Public License as published
 *   by the Free Software Foundation; either version 2.1 of the License, or
 *   (at your option) any later version.
 *
 *   This library is distributed in the hope that it will be useful,
 *   but WITHOUT ANY WARRANTY; without even the implied warranty of
 *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See
 *   the GNU Lesser General Public License for more details.
 *
 *   You should have received a copy of the GNU Lesser General Public License
 *   along with this library; if not, write to the Free Software
 *   Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
 */
#include <linux/fs.h>
25
#include <linux/backing-dev.h>
L
Linus Torvalds 已提交
26 27 28 29
#include <linux/stat.h>
#include <linux/fcntl.h>
#include <linux/pagemap.h>
#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>
L
Linus Torvalds 已提交
35 36 37 38 39 40 41 42
#include <asm/div64.h>
#include "cifsfs.h"
#include "cifspdu.h"
#include "cifsglob.h"
#include "cifsproto.h"
#include "cifs_unicode.h"
#include "cifs_debug.h"
#include "cifs_fs_sb.h"
43
#include "fscache.h"
L
Linus Torvalds 已提交
44 45 46 47 48 49 50 51 52 53 54 55 56 57

static inline int cifs_convert_flags(unsigned int flags)
{
	if ((flags & O_ACCMODE) == O_RDONLY)
		return GENERIC_READ;
	else if ((flags & O_ACCMODE) == O_WRONLY)
		return GENERIC_WRITE;
	else if ((flags & O_ACCMODE) == O_RDWR) {
		/* GENERIC_ALL is too much permission to request
		   can cause unnecessary access denied on create */
		/* return GENERIC_ALL; */
		return (GENERIC_READ | GENERIC_WRITE);
	}

58 59 60
	return (READ_CONTROL | FILE_WRITE_ATTRIBUTES | FILE_READ_ATTRIBUTES |
		FILE_WRITE_EA | FILE_APPEND_DATA | FILE_WRITE_DATA |
		FILE_READ_DATA);
61
}
62

63
static u32 cifs_posix_convert_flags(unsigned int flags)
64
{
65
	u32 posix_flags = 0;
66

67
	if ((flags & O_ACCMODE) == O_RDONLY)
68
		posix_flags = SMB_O_RDONLY;
69
	else if ((flags & O_ACCMODE) == O_WRONLY)
70 71 72 73 74 75 76 77 78 79 80
		posix_flags = SMB_O_WRONLY;
	else if ((flags & O_ACCMODE) == O_RDWR)
		posix_flags = SMB_O_RDWR;

	if (flags & O_CREAT)
		posix_flags |= SMB_O_CREAT;
	if (flags & O_EXCL)
		posix_flags |= SMB_O_EXCL;
	if (flags & O_TRUNC)
		posix_flags |= SMB_O_TRUNC;
	/* be safe and imply O_SYNC for O_DSYNC */
81
	if (flags & O_DSYNC)
82
		posix_flags |= SMB_O_SYNC;
83
	if (flags & O_DIRECTORY)
84
		posix_flags |= SMB_O_DIRECTORY;
85
	if (flags & O_NOFOLLOW)
86
		posix_flags |= SMB_O_NOFOLLOW;
87
	if (flags & O_DIRECT)
88
		posix_flags |= SMB_O_DIRECT;
89 90

	return posix_flags;
L
Linus Torvalds 已提交
91 92 93 94 95 96 97 98 99 100
}

static inline int cifs_get_disposition(unsigned int flags)
{
	if ((flags & (O_CREAT | O_EXCL)) == (O_CREAT | O_EXCL))
		return FILE_CREATE;
	else if ((flags & (O_CREAT | O_TRUNC)) == (O_CREAT | O_TRUNC))
		return FILE_OVERWRITE_IF;
	else if ((flags & O_CREAT) == O_CREAT)
		return FILE_OPEN_IF;
101 102
	else if ((flags & O_TRUNC) == O_TRUNC)
		return FILE_OVERWRITE;
L
Linus Torvalds 已提交
103 104 105 106
	else
		return FILE_OPEN;
}

107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168
int cifs_posix_open(char *full_path, struct inode **pinode,
			struct super_block *sb, int mode, unsigned int f_flags,
			__u32 *poplock, __u16 *pnetfid, int xid)
{
	int rc;
	FILE_UNIX_BASIC_INFO *presp_data;
	__u32 posix_flags = 0;
	struct cifs_sb_info *cifs_sb = CIFS_SB(sb);
	struct cifs_fattr fattr;
	struct tcon_link *tlink;
	struct cifsTconInfo *tcon;

	cFYI(1, "posix open %s", full_path);

	presp_data = kzalloc(sizeof(FILE_UNIX_BASIC_INFO), GFP_KERNEL);
	if (presp_data == NULL)
		return -ENOMEM;

	tlink = cifs_sb_tlink(cifs_sb);
	if (IS_ERR(tlink)) {
		rc = PTR_ERR(tlink);
		goto posix_open_ret;
	}

	tcon = tlink_tcon(tlink);
	mode &= ~current_umask();

	posix_flags = cifs_posix_convert_flags(f_flags);
	rc = CIFSPOSIXCreate(xid, tcon, posix_flags, mode, pnetfid, presp_data,
			     poplock, full_path, cifs_sb->local_nls,
			     cifs_sb->mnt_cifs_flags &
					CIFS_MOUNT_MAP_SPECIAL_CHR);
	cifs_put_tlink(tlink);

	if (rc)
		goto posix_open_ret;

	if (presp_data->Type == cpu_to_le32(-1))
		goto posix_open_ret; /* open ok, caller does qpathinfo */

	if (!pinode)
		goto posix_open_ret; /* caller does not need info */

	cifs_unix_basic_to_fattr(&fattr, presp_data, cifs_sb);

	/* get new inode and set it up */
	if (*pinode == NULL) {
		cifs_fill_uniqueid(sb, &fattr);
		*pinode = cifs_iget(sb, &fattr);
		if (!*pinode) {
			rc = -ENOMEM;
			goto posix_open_ret;
		}
	} else {
		cifs_fattr_to_inode(*pinode, &fattr);
	}

posix_open_ret:
	kfree(presp_data);
	return rc;
}

169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238
static int
cifs_nt_open(char *full_path, struct inode *inode, struct cifs_sb_info *cifs_sb,
	     struct cifsTconInfo *tcon, unsigned int f_flags, __u32 *poplock,
	     __u16 *pnetfid, int xid)
{
	int rc;
	int desiredAccess;
	int disposition;
	FILE_ALL_INFO *buf;

	desiredAccess = cifs_convert_flags(f_flags);

/*********************************************************************
 *  open flag mapping table:
 *
 *	POSIX Flag            CIFS Disposition
 *	----------            ----------------
 *	O_CREAT               FILE_OPEN_IF
 *	O_CREAT | O_EXCL      FILE_CREATE
 *	O_CREAT | O_TRUNC     FILE_OVERWRITE_IF
 *	O_TRUNC               FILE_OVERWRITE
 *	none of the above     FILE_OPEN
 *
 *	Note that there is not a direct match between disposition
 *	FILE_SUPERSEDE (ie create whether or not file exists although
 *	O_CREAT | O_TRUNC is similar but truncates the existing
 *	file rather than creating a new file as FILE_SUPERSEDE does
 *	(which uses the attributes / metadata passed in on open call)
 *?
 *?  O_SYNC is a reasonable match to CIFS writethrough flag
 *?  and the read write flags match reasonably.  O_LARGEFILE
 *?  is irrelevant because largefile support is always used
 *?  by this client. Flags O_APPEND, O_DIRECT, O_DIRECTORY,
 *	 O_FASYNC, O_NOFOLLOW, O_NONBLOCK need further investigation
 *********************************************************************/

	disposition = cifs_get_disposition(f_flags);

	/* BB pass O_SYNC flag through on file attributes .. BB */

	buf = kmalloc(sizeof(FILE_ALL_INFO), GFP_KERNEL);
	if (!buf)
		return -ENOMEM;

	if (tcon->ses->capabilities & CAP_NT_SMBS)
		rc = CIFSSMBOpen(xid, tcon, full_path, disposition,
			 desiredAccess, CREATE_NOT_DIR, pnetfid, poplock, buf,
			 cifs_sb->local_nls, cifs_sb->mnt_cifs_flags
				 & CIFS_MOUNT_MAP_SPECIAL_CHR);
	else
		rc = SMBLegacyOpen(xid, tcon, full_path, disposition,
			desiredAccess, CREATE_NOT_DIR, pnetfid, poplock, buf,
			cifs_sb->local_nls, cifs_sb->mnt_cifs_flags
				& CIFS_MOUNT_MAP_SPECIAL_CHR);

	if (rc)
		goto out;

	if (tcon->unix_ext)
		rc = cifs_get_inode_info_unix(&inode, full_path, inode->i_sb,
					      xid);
	else
		rc = cifs_get_inode_info(&inode, full_path, buf, inode->i_sb,
					 xid, pnetfid);

out:
	kfree(buf);
	return rc;
}

239 240 241 242 243 244 245 246 247 248 249 250 251
struct cifsFileInfo *
cifs_new_fileinfo(__u16 fileHandle, struct file *file,
		  struct tcon_link *tlink, __u32 oplock)
{
	struct dentry *dentry = file->f_path.dentry;
	struct inode *inode = dentry->d_inode;
	struct cifsInodeInfo *pCifsInode = CIFS_I(inode);
	struct cifsFileInfo *pCifsFile;

	pCifsFile = kzalloc(sizeof(struct cifsFileInfo), GFP_KERNEL);
	if (pCifsFile == NULL)
		return pCifsFile;

252
	pCifsFile->count = 1;
253 254 255 256 257 258 259 260 261 262 263 264
	pCifsFile->netfid = fileHandle;
	pCifsFile->pid = current->tgid;
	pCifsFile->uid = current_fsuid();
	pCifsFile->dentry = dget(dentry);
	pCifsFile->f_flags = file->f_flags;
	pCifsFile->invalidHandle = false;
	pCifsFile->tlink = cifs_get_tlink(tlink);
	mutex_init(&pCifsFile->fh_mutex);
	mutex_init(&pCifsFile->lock_mutex);
	INIT_LIST_HEAD(&pCifsFile->llist);
	INIT_WORK(&pCifsFile->oplock_break, cifs_oplock_break);

265
	spin_lock(&cifs_file_list_lock);
266 267 268 269 270 271
	list_add(&pCifsFile->tlist, &(tlink_tcon(tlink)->openFileList));
	/* if readable file instance put first in list*/
	if (file->f_mode & FMODE_READ)
		list_add(&pCifsFile->flist, &pCifsInode->openFileList);
	else
		list_add_tail(&pCifsFile->flist, &pCifsInode->openFileList);
272
	spin_unlock(&cifs_file_list_lock);
273

274
	cifs_set_oplock_level(pCifsInode, oplock);
275 276 277 278 279

	file->private_data = pCifsFile;
	return pCifsFile;
}

280 281
/*
 * Release a reference on the file private data. This may involve closing
282 283
 * the filehandle out on the server. Must be called without holding
 * cifs_file_list_lock.
284
 */
285 286
void cifsFileInfo_put(struct cifsFileInfo *cifs_file)
{
P
Pavel Shilovsky 已提交
287
	struct inode *inode = cifs_file->dentry->d_inode;
288
	struct cifsTconInfo *tcon = tlink_tcon(cifs_file->tlink);
P
Pavel Shilovsky 已提交
289
	struct cifsInodeInfo *cifsi = CIFS_I(inode);
290
	struct cifs_sb_info *cifs_sb = CIFS_SB(inode->i_sb);
291 292 293
	struct cifsLockInfo *li, *tmp;

	spin_lock(&cifs_file_list_lock);
294
	if (--cifs_file->count > 0) {
295 296 297 298 299 300 301 302 303 304 305
		spin_unlock(&cifs_file_list_lock);
		return;
	}

	/* remove it from the lists */
	list_del(&cifs_file->flist);
	list_del(&cifs_file->tlist);

	if (list_empty(&cifsi->openFileList)) {
		cFYI(1, "closing last open instance for inode %p",
			cifs_file->dentry->d_inode);
306 307 308 309 310 311 312

		/* in strict cache mode we need invalidate mapping on the last
		   close  because it may cause a error when we open this file
		   again and get at least level II oplock */
		if (cifs_sb->mnt_cifs_flags & CIFS_MOUNT_STRICT_IO)
			CIFS_I(inode)->invalid_mapping = true;

313
		cifs_set_oplock_level(cifsi, 0);
314 315 316 317 318 319 320 321 322 323 324 325 326 327 328 329 330 331
	}
	spin_unlock(&cifs_file_list_lock);

	if (!tcon->need_reconnect && !cifs_file->invalidHandle) {
		int xid, rc;

		xid = GetXid();
		rc = CIFSSMBClose(xid, tcon, cifs_file->netfid);
		FreeXid(xid);
	}

	/* Delete any outstanding lock records. We'll lose them when the file
	 * is closed anyway.
	 */
	mutex_lock(&cifs_file->lock_mutex);
	list_for_each_entry_safe(li, tmp, &cifs_file->llist, llist) {
		list_del(&li->llist);
		kfree(li);
332
	}
333 334 335 336 337
	mutex_unlock(&cifs_file->lock_mutex);

	cifs_put_tlink(cifs_file->tlink);
	dput(cifs_file->dentry);
	kfree(cifs_file);
338 339
}

L
Linus Torvalds 已提交
340 341 342
int cifs_open(struct inode *inode, struct file *file)
{
	int rc = -EACCES;
343 344
	int xid;
	__u32 oplock;
L
Linus Torvalds 已提交
345
	struct cifs_sb_info *cifs_sb;
346
	struct cifsTconInfo *tcon;
347
	struct tcon_link *tlink;
348
	struct cifsFileInfo *pCifsFile = NULL;
L
Linus Torvalds 已提交
349 350
	struct cifsInodeInfo *pCifsInode;
	char *full_path = NULL;
P
Pavel Shilovsky 已提交
351
	bool posix_open_ok = false;
L
Linus Torvalds 已提交
352 353 354 355 356
	__u16 netfid;

	xid = GetXid();

	cifs_sb = CIFS_SB(inode->i_sb);
357 358 359 360 361 362
	tlink = cifs_sb_tlink(cifs_sb);
	if (IS_ERR(tlink)) {
		FreeXid(xid);
		return PTR_ERR(tlink);
	}
	tcon = tlink_tcon(tlink);
L
Linus Torvalds 已提交
363

364
	pCifsInode = CIFS_I(file->f_path.dentry->d_inode);
L
Linus Torvalds 已提交
365

366
	full_path = build_path_from_dentry(file->f_path.dentry);
L
Linus Torvalds 已提交
367
	if (full_path == NULL) {
368
		rc = -ENOMEM;
369
		goto out;
L
Linus Torvalds 已提交
370 371
	}

372 373
	cFYI(1, "inode = 0x%p file flags are 0x%x for %s",
		 inode, file->f_flags, full_path);
374 375 376 377 378 379

	if (oplockEnabled)
		oplock = REQ_OPLOCK;
	else
		oplock = 0;

380 381
	if (!tcon->broken_posix_open && tcon->unix_ext &&
	    (tcon->ses->capabilities & CAP_UNIX) &&
382 383 384
	    (CIFS_UNIX_POSIX_PATH_OPS_CAP &
			le64_to_cpu(tcon->fsUnixInfo.Capability))) {
		/* can not refresh inode info since size could be stale */
385
		rc = cifs_posix_open(full_path, &inode, inode->i_sb,
386
				cifs_sb->mnt_file_mode /* ignored */,
387
				file->f_flags, &oplock, &netfid, xid);
388
		if (rc == 0) {
389
			cFYI(1, "posix open succeeded");
P
Pavel Shilovsky 已提交
390
			posix_open_ok = true;
391 392
		} else if ((rc == -EINVAL) || (rc == -EOPNOTSUPP)) {
			if (tcon->ses->serverNOS)
393
				cERROR(1, "server %s of type %s returned"
394 395 396 397
					   " unexpected error on SMB posix open"
					   ", disabling posix open support."
					   " Check if server update available.",
					   tcon->ses->serverName,
398
					   tcon->ses->serverNOS);
399
			tcon->broken_posix_open = true;
400 401 402
		} else if ((rc != -EIO) && (rc != -EREMOTE) &&
			 (rc != -EOPNOTSUPP)) /* path not found or net err */
			goto out;
403 404
		/* else fallthrough to retry open the old way on network i/o
		   or DFS errors */
405 406
	}

P
Pavel Shilovsky 已提交
407 408 409 410 411 412
	if (!posix_open_ok) {
		rc = cifs_nt_open(full_path, inode, cifs_sb, tcon,
				  file->f_flags, &oplock, &netfid, xid);
		if (rc)
			goto out;
	}
413

414
	pCifsFile = cifs_new_fileinfo(netfid, file, tlink, oplock);
415
	if (pCifsFile == NULL) {
P
Pavel Shilovsky 已提交
416
		CIFSSMBClose(xid, tcon, netfid);
L
Linus Torvalds 已提交
417 418 419 420
		rc = -ENOMEM;
		goto out;
	}

421 422
	cifs_fscache_set_inode_cookie(inode, file);

P
Pavel Shilovsky 已提交
423
	if ((oplock & CIFS_CREATE_ACTION) && !posix_open_ok && tcon->unix_ext) {
L
Linus Torvalds 已提交
424 425
		/* time to set mode which we can not set earlier due to
		   problems creating new read-only files */
P
Pavel Shilovsky 已提交
426 427 428 429 430 431 432 433 434
		struct cifs_unix_set_info_args args = {
			.mode	= inode->i_mode,
			.uid	= NO_CHANGE_64,
			.gid	= NO_CHANGE_64,
			.ctime	= NO_CHANGE_64,
			.atime	= NO_CHANGE_64,
			.mtime	= NO_CHANGE_64,
			.device	= 0,
		};
435 436
		CIFSSMBUnixSetFileInfo(xid, tcon, &args, netfid,
					pCifsFile->pid);
L
Linus Torvalds 已提交
437 438 439 440 441
	}

out:
	kfree(full_path);
	FreeXid(xid);
442
	cifs_put_tlink(tlink);
L
Linus Torvalds 已提交
443 444 445
	return rc;
}

A
Adrian Bunk 已提交
446
/* Try to reacquire byte range locks that were released when session */
L
Linus Torvalds 已提交
447 448 449 450 451 452 453 454 455 456
/* to server was lost */
static int cifs_relock_file(struct cifsFileInfo *cifsFile)
{
	int rc = 0;

/* BB list all locks open on this file and relock */

	return rc;
}

J
Jeff Layton 已提交
457
static int cifs_reopen_file(struct cifsFileInfo *pCifsFile, bool can_flush)
L
Linus Torvalds 已提交
458 459
{
	int rc = -EACCES;
460 461
	int xid;
	__u32 oplock;
L
Linus Torvalds 已提交
462
	struct cifs_sb_info *cifs_sb;
463
	struct cifsTconInfo *tcon;
L
Linus Torvalds 已提交
464
	struct cifsInodeInfo *pCifsInode;
S
Steve French 已提交
465
	struct inode *inode;
L
Linus Torvalds 已提交
466 467 468 469 470 471
	char *full_path = NULL;
	int desiredAccess;
	int disposition = FILE_OPEN;
	__u16 netfid;

	xid = GetXid();
472
	mutex_lock(&pCifsFile->fh_mutex);
473
	if (!pCifsFile->invalidHandle) {
474
		mutex_unlock(&pCifsFile->fh_mutex);
475
		rc = 0;
L
Linus Torvalds 已提交
476
		FreeXid(xid);
477
		return rc;
L
Linus Torvalds 已提交
478 479
	}

J
Jeff Layton 已提交
480
	inode = pCifsFile->dentry->d_inode;
L
Linus Torvalds 已提交
481
	cifs_sb = CIFS_SB(inode->i_sb);
482
	tcon = tlink_tcon(pCifsFile->tlink);
483

L
Linus Torvalds 已提交
484 485 486 487
/* can not grab rename sem here because various ops, including
   those that already have the rename sem can end up causing writepage
   to get called and if the server was down that means we end up here,
   and we can never tell if the caller already has the rename_sem */
J
Jeff Layton 已提交
488
	full_path = build_path_from_dentry(pCifsFile->dentry);
L
Linus Torvalds 已提交
489
	if (full_path == NULL) {
490
		rc = -ENOMEM;
491
		mutex_unlock(&pCifsFile->fh_mutex);
L
Linus Torvalds 已提交
492
		FreeXid(xid);
493
		return rc;
L
Linus Torvalds 已提交
494 495
	}

496
	cFYI(1, "inode = 0x%p file flags 0x%x for %s",
J
Jeff Layton 已提交
497
		 inode, pCifsFile->f_flags, full_path);
L
Linus Torvalds 已提交
498 499 500 501

	if (oplockEnabled)
		oplock = REQ_OPLOCK;
	else
502
		oplock = 0;
L
Linus Torvalds 已提交
503

504 505 506
	if (tcon->unix_ext && (tcon->ses->capabilities & CAP_UNIX) &&
	    (CIFS_UNIX_POSIX_PATH_OPS_CAP &
			le64_to_cpu(tcon->fsUnixInfo.Capability))) {
507 508 509 510 511

		/*
		 * O_CREAT, O_EXCL and O_TRUNC already had their effect on the
		 * original open. Must mask them off for a reopen.
		 */
J
Jeff Layton 已提交
512 513
		unsigned int oflags = pCifsFile->f_flags &
						~(O_CREAT | O_EXCL | O_TRUNC);
514

515
		rc = cifs_posix_open(full_path, NULL, inode->i_sb,
516 517
				cifs_sb->mnt_file_mode /* ignored */,
				oflags, &oplock, &netfid, xid);
518
		if (rc == 0) {
519
			cFYI(1, "posix reopen succeeded");
520 521 522 523 524 525
			goto reopen_success;
		}
		/* fallthrough to retry open the old way on errors, especially
		   in the reconnect path it is important to retry hard */
	}

J
Jeff Layton 已提交
526
	desiredAccess = cifs_convert_flags(pCifsFile->f_flags);
527

L
Linus Torvalds 已提交
528
	/* Can not refresh inode by passing in file_info buf to be returned
S
Steve French 已提交
529 530
	   by SMBOpen and then calling get_inode_info with returned buf
	   since file might have write behind data that needs to be flushed
L
Linus Torvalds 已提交
531 532 533
	   and server version of file size can be stale. If we knew for sure
	   that inode was not dirty locally we could do this */

534
	rc = CIFSSMBOpen(xid, tcon, full_path, disposition, desiredAccess,
L
Linus Torvalds 已提交
535
			 CREATE_NOT_DIR, &netfid, &oplock, NULL,
S
Steve French 已提交
536
			 cifs_sb->local_nls, cifs_sb->mnt_cifs_flags &
537
				CIFS_MOUNT_MAP_SPECIAL_CHR);
L
Linus Torvalds 已提交
538
	if (rc) {
539
		mutex_unlock(&pCifsFile->fh_mutex);
540 541
		cFYI(1, "cifs_open returned 0x%x", rc);
		cFYI(1, "oplock: %d", oplock);
J
Jeff Layton 已提交
542 543 544
		goto reopen_error_exit;
	}

545
reopen_success:
J
Jeff Layton 已提交
546 547 548 549 550 551 552
	pCifsFile->netfid = netfid;
	pCifsFile->invalidHandle = false;
	mutex_unlock(&pCifsFile->fh_mutex);
	pCifsInode = CIFS_I(inode);

	if (can_flush) {
		rc = filemap_write_and_wait(inode->i_mapping);
553
		mapping_set_error(inode->i_mapping, rc);
J
Jeff Layton 已提交
554 555 556 557 558 559 560 561 562 563 564 565 566 567

		if (tcon->unix_ext)
			rc = cifs_get_inode_info_unix(&inode,
				full_path, inode->i_sb, xid);
		else
			rc = cifs_get_inode_info(&inode,
				full_path, NULL, inode->i_sb,
				xid, NULL);
	} /* else we are writing out data to server already
	     and could deadlock if we tried to flush data, and
	     since we do not know if we have data that would
	     invalidate the current end of file on the server
	     we can not go to the server to get the new inod
	     info */
P
Pavel Shilovsky 已提交
568

569
	cifs_set_oplock_level(pCifsInode, oplock);
P
Pavel Shilovsky 已提交
570

J
Jeff Layton 已提交
571 572 573
	cifs_relock_file(pCifsFile);

reopen_error_exit:
L
Linus Torvalds 已提交
574 575 576 577 578 579 580
	kfree(full_path);
	FreeXid(xid);
	return rc;
}

int cifs_close(struct inode *inode, struct file *file)
{
581 582
	cifsFileInfo_put(file->private_data);
	file->private_data = NULL;
J
[CIFS]  
Jeremy Allison 已提交
583

584 585
	/* return code from the ->release op is always ignored */
	return 0;
L
Linus Torvalds 已提交
586 587 588 589 590 591
}

int cifs_closedir(struct inode *inode, struct file *file)
{
	int rc = 0;
	int xid;
592
	struct cifsFileInfo *pCFileStruct = file->private_data;
L
Linus Torvalds 已提交
593 594
	char *ptmp;

595
	cFYI(1, "Closedir inode = 0x%p", inode);
L
Linus Torvalds 已提交
596 597 598 599

	xid = GetXid();

	if (pCFileStruct) {
600
		struct cifsTconInfo *pTcon = tlink_tcon(pCFileStruct->tlink);
L
Linus Torvalds 已提交
601

602
		cFYI(1, "Freeing private data in close dir");
603
		spin_lock(&cifs_file_list_lock);
604 605 606
		if (!pCFileStruct->srch_inf.endOfSearch &&
		    !pCFileStruct->invalidHandle) {
			pCFileStruct->invalidHandle = true;
607
			spin_unlock(&cifs_file_list_lock);
L
Linus Torvalds 已提交
608
			rc = CIFSFindClose(xid, pTcon, pCFileStruct->netfid);
609 610
			cFYI(1, "Closing uncompleted readdir with rc %d",
				 rc);
L
Linus Torvalds 已提交
611 612
			/* not much we can do if it fails anyway, ignore rc */
			rc = 0;
613
		} else
614
			spin_unlock(&cifs_file_list_lock);
L
Linus Torvalds 已提交
615 616
		ptmp = pCFileStruct->srch_inf.ntwrk_buf_start;
		if (ptmp) {
617
			cFYI(1, "closedir free smb buf in srch struct");
L
Linus Torvalds 已提交
618
			pCFileStruct->srch_inf.ntwrk_buf_start = NULL;
S
Steve French 已提交
619
			if (pCFileStruct->srch_inf.smallBuf)
620 621 622
				cifs_small_buf_release(ptmp);
			else
				cifs_buf_release(ptmp);
L
Linus Torvalds 已提交
623
		}
624
		cifs_put_tlink(pCFileStruct->tlink);
L
Linus Torvalds 已提交
625 626 627 628 629 630 631 632
		kfree(file->private_data);
		file->private_data = NULL;
	}
	/* BB can we lock the filestruct while this is going on? */
	FreeXid(xid);
	return rc;
}

J
[CIFS]  
Jeremy Allison 已提交
633 634 635
static int store_file_lock(struct cifsFileInfo *fid, __u64 len,
				__u64 offset, __u8 lockType)
{
S
Steve French 已提交
636 637
	struct cifsLockInfo *li =
		kmalloc(sizeof(struct cifsLockInfo), GFP_KERNEL);
J
[CIFS]  
Jeremy Allison 已提交
638 639 640 641 642
	if (li == NULL)
		return -ENOMEM;
	li->offset = offset;
	li->length = len;
	li->type = lockType;
643
	mutex_lock(&fid->lock_mutex);
J
[CIFS]  
Jeremy Allison 已提交
644
	list_add(&li->llist, &fid->llist);
645
	mutex_unlock(&fid->lock_mutex);
J
[CIFS]  
Jeremy Allison 已提交
646 647 648
	return 0;
}

L
Linus Torvalds 已提交
649 650 651 652 653 654
int cifs_lock(struct file *file, int cmd, struct file_lock *pfLock)
{
	int rc, xid;
	__u32 numLock = 0;
	__u32 numUnlock = 0;
	__u64 length;
655
	bool wait_flag = false;
L
Linus Torvalds 已提交
656
	struct cifs_sb_info *cifs_sb;
657
	struct cifsTconInfo *tcon;
658 659
	__u16 netfid;
	__u8 lockType = LOCKING_ANDX_LARGE_FILES;
660
	bool posix_locking = 0;
L
Linus Torvalds 已提交
661 662 663 664 665

	length = 1 + pfLock->fl_end - pfLock->fl_start;
	rc = -EACCES;
	xid = GetXid();

666
	cFYI(1, "Lock parm: 0x%x flockflags: "
L
Linus Torvalds 已提交
667
		 "0x%x flocktype: 0x%x start: %lld end: %lld",
S
Steve French 已提交
668
		cmd, pfLock->fl_flags, pfLock->fl_type, pfLock->fl_start,
669
		pfLock->fl_end);
L
Linus Torvalds 已提交
670 671

	if (pfLock->fl_flags & FL_POSIX)
672
		cFYI(1, "Posix");
L
Linus Torvalds 已提交
673
	if (pfLock->fl_flags & FL_FLOCK)
674
		cFYI(1, "Flock");
L
Linus Torvalds 已提交
675
	if (pfLock->fl_flags & FL_SLEEP) {
676
		cFYI(1, "Blocking lock");
677
		wait_flag = true;
L
Linus Torvalds 已提交
678 679
	}
	if (pfLock->fl_flags & FL_ACCESS)
680 681
		cFYI(1, "Process suspended by mandatory locking - "
			 "not implemented yet");
L
Linus Torvalds 已提交
682
	if (pfLock->fl_flags & FL_LEASE)
683
		cFYI(1, "Lease on file - not implemented yet");
S
Steve French 已提交
684
	if (pfLock->fl_flags &
L
Linus Torvalds 已提交
685
	    (~(FL_POSIX | FL_FLOCK | FL_SLEEP | FL_ACCESS | FL_LEASE)))
686
		cFYI(1, "Unknown lock flags 0x%x", pfLock->fl_flags);
L
Linus Torvalds 已提交
687 688

	if (pfLock->fl_type == F_WRLCK) {
689
		cFYI(1, "F_WRLCK ");
L
Linus Torvalds 已提交
690 691
		numLock = 1;
	} else if (pfLock->fl_type == F_UNLCK) {
692
		cFYI(1, "F_UNLCK");
L
Linus Torvalds 已提交
693
		numUnlock = 1;
694 695
		/* Check if unlock includes more than
		one lock range */
L
Linus Torvalds 已提交
696
	} else if (pfLock->fl_type == F_RDLCK) {
697
		cFYI(1, "F_RDLCK");
L
Linus Torvalds 已提交
698 699 700
		lockType |= LOCKING_ANDX_SHARED_LOCK;
		numLock = 1;
	} else if (pfLock->fl_type == F_EXLCK) {
701
		cFYI(1, "F_EXLCK");
L
Linus Torvalds 已提交
702 703
		numLock = 1;
	} else if (pfLock->fl_type == F_SHLCK) {
704
		cFYI(1, "F_SHLCK");
L
Linus Torvalds 已提交
705 706 707
		lockType |= LOCKING_ANDX_SHARED_LOCK;
		numLock = 1;
	} else
708
		cFYI(1, "Unknown type of lock");
L
Linus Torvalds 已提交
709

710
	cifs_sb = CIFS_SB(file->f_path.dentry->d_sb);
711
	tcon = tlink_tcon(((struct cifsFileInfo *)file->private_data)->tlink);
712 713
	netfid = ((struct cifsFileInfo *)file->private_data)->netfid;

714 715
	if ((tcon->ses->capabilities & CAP_UNIX) &&
	    (CIFS_UNIX_FCNTL_CAP & le64_to_cpu(tcon->fsUnixInfo.Capability)) &&
S
Steve French 已提交
716
	    ((cifs_sb->mnt_cifs_flags & CIFS_MOUNT_NOPOSIXBRL) == 0))
717
		posix_locking = 1;
718 719 720
	/* BB add code here to normalize offset and length to
	account for negative length which we can not accept over the
	wire */
L
Linus Torvalds 已提交
721
	if (IS_GETLK(cmd)) {
S
Steve French 已提交
722
		if (posix_locking) {
723
			int posix_lock_type;
S
Steve French 已提交
724
			if (lockType & LOCKING_ANDX_SHARED_LOCK)
725 726 727
				posix_lock_type = CIFS_RDLCK;
			else
				posix_lock_type = CIFS_WRLCK;
728
			rc = CIFSSMBPosixLock(xid, tcon, netfid, 1 /* get */,
729
					length,	pfLock,
730 731 732 733 734 735
					posix_lock_type, wait_flag);
			FreeXid(xid);
			return rc;
		}

		/* BB we could chain these into one lock request BB */
736
		rc = CIFSSMBLock(xid, tcon, netfid, length, pfLock->fl_start,
737
				 0, 1, lockType, 0 /* wait flag */, 0);
L
Linus Torvalds 已提交
738
		if (rc == 0) {
739
			rc = CIFSSMBLock(xid, tcon, netfid, length,
L
Linus Torvalds 已提交
740 741
					 pfLock->fl_start, 1 /* numUnlock */ ,
					 0 /* numLock */ , lockType,
742
					 0 /* wait flag */, 0);
L
Linus Torvalds 已提交
743 744
			pfLock->fl_type = F_UNLCK;
			if (rc != 0)
745 746
				cERROR(1, "Error unlocking previously locked "
					   "range %d during test of lock", rc);
L
Linus Torvalds 已提交
747 748 749 750
			rc = 0;

		} else {
			/* if rc == ERR_SHARING_VIOLATION ? */
751 752 753 754 755 756 757 758
			rc = 0;

			if (lockType & LOCKING_ANDX_SHARED_LOCK) {
				pfLock->fl_type = F_WRLCK;
			} else {
				rc = CIFSSMBLock(xid, tcon, netfid, length,
					pfLock->fl_start, 0, 1,
					lockType | LOCKING_ANDX_SHARED_LOCK,
759
					0 /* wait flag */, 0);
760 761 762 763 764
				if (rc == 0) {
					rc = CIFSSMBLock(xid, tcon, netfid,
						length, pfLock->fl_start, 1, 0,
						lockType |
						LOCKING_ANDX_SHARED_LOCK,
765
						0 /* wait flag */, 0);
766 767
					pfLock->fl_type = F_RDLCK;
					if (rc != 0)
768
						cERROR(1, "Error unlocking "
769
						"previously locked range %d "
770
						"during test of lock", rc);
771 772 773 774 775 776
					rc = 0;
				} else {
					pfLock->fl_type = F_WRLCK;
					rc = 0;
				}
			}
L
Linus Torvalds 已提交
777 778 779 780 781
		}

		FreeXid(xid);
		return rc;
	}
J
[CIFS]  
Jeremy Allison 已提交
782 783 784 785 786 787 788 789 790

	if (!numLock && !numUnlock) {
		/* if no lock or unlock then nothing
		to do since we do not know what it is */
		FreeXid(xid);
		return -EOPNOTSUPP;
	}

	if (posix_locking) {
791
		int posix_lock_type;
S
Steve French 已提交
792
		if (lockType & LOCKING_ANDX_SHARED_LOCK)
793 794 795
			posix_lock_type = CIFS_RDLCK;
		else
			posix_lock_type = CIFS_WRLCK;
796

S
Steve French 已提交
797
		if (numUnlock == 1)
798
			posix_lock_type = CIFS_UNLCK;
J
[CIFS]  
Jeremy Allison 已提交
799

800
		rc = CIFSSMBPosixLock(xid, tcon, netfid, 0 /* set */,
801
				      length, pfLock,
802
				      posix_lock_type, wait_flag);
J
[CIFS]  
Jeremy Allison 已提交
803
	} else {
804
		struct cifsFileInfo *fid = file->private_data;
J
[CIFS]  
Jeremy Allison 已提交
805 806

		if (numLock) {
807
			rc = CIFSSMBLock(xid, tcon, netfid, length,
808 809
					 pfLock->fl_start, 0, numLock, lockType,
					 wait_flag, 0);
J
[CIFS]  
Jeremy Allison 已提交
810 811 812 813 814 815 816 817 818 819 820 821

			if (rc == 0) {
				/* For Windows locks we must store them. */
				rc = store_file_lock(fid, length,
						pfLock->fl_start, lockType);
			}
		} else if (numUnlock) {
			/* For each stored lock that this unlock overlaps
			   completely, unlock it. */
			int stored_rc = 0;
			struct cifsLockInfo *li, *tmp;

822
			rc = 0;
823
			mutex_lock(&fid->lock_mutex);
J
[CIFS]  
Jeremy Allison 已提交
824 825
			list_for_each_entry_safe(li, tmp, &fid->llist, llist) {
				if (pfLock->fl_start <= li->offset &&
S
Steve French 已提交
826
						(pfLock->fl_start + length) >=
827
						(li->offset + li->length)) {
828
					stored_rc = CIFSSMBLock(xid, tcon,
829 830 831
							netfid, li->length,
							li->offset, 1, 0,
							li->type, false, 0);
J
[CIFS]  
Jeremy Allison 已提交
832 833
					if (stored_rc)
						rc = stored_rc;
834 835 836 837
					else {
						list_del(&li->llist);
						kfree(li);
					}
J
[CIFS]  
Jeremy Allison 已提交
838 839
				}
			}
840
			mutex_unlock(&fid->lock_mutex);
J
[CIFS]  
Jeremy Allison 已提交
841 842 843
		}
	}

844
	if (pfLock->fl_flags & FL_POSIX)
L
Linus Torvalds 已提交
845 846 847 848 849
		posix_lock_file_wait(file, pfLock);
	FreeXid(xid);
	return rc;
}

850 851 852 853 854 855 856 857 858 859 860
/* update the file size (if needed) after a write */
static void
cifs_update_eof(struct cifsInodeInfo *cifsi, loff_t offset,
		      unsigned int bytes_written)
{
	loff_t end_of_write = offset + bytes_written;

	if (end_of_write > cifsi->server_eof)
		cifsi->server_eof = end_of_write;
}

L
Linus Torvalds 已提交
861 862 863
ssize_t cifs_user_write(struct file *file, const char __user *write_data,
	size_t write_size, loff_t *poffset)
{
J
Jiri Slaby 已提交
864
	struct inode *inode = file->f_path.dentry->d_inode;
L
Linus Torvalds 已提交
865 866 867 868 869
	int rc = 0;
	unsigned int bytes_written = 0;
	unsigned int total_written;
	struct cifs_sb_info *cifs_sb;
	struct cifsTconInfo *pTcon;
870
	int xid;
L
Linus Torvalds 已提交
871
	struct cifsFileInfo *open_file;
J
Jiri Slaby 已提交
872
	struct cifsInodeInfo *cifsi = CIFS_I(inode);
L
Linus Torvalds 已提交
873

874
	cifs_sb = CIFS_SB(file->f_path.dentry->d_sb);
L
Linus Torvalds 已提交
875

876 877
	/* cFYI(1, " write %d bytes to offset %lld of %s", write_size,
	   *poffset, file->f_path.dentry->d_name.name); */
L
Linus Torvalds 已提交
878 879 880

	if (file->private_data == NULL)
		return -EBADF;
881

882
	open_file = file->private_data;
883
	pTcon = tlink_tcon(open_file->tlink);
884

885 886 887 888
	rc = generic_write_checks(file, poffset, &write_size, 0);
	if (rc)
		return rc;

L
Linus Torvalds 已提交
889 890 891 892 893 894 895 896 897 898 899 900 901
	xid = GetXid();

	for (total_written = 0; write_size > total_written;
	     total_written += bytes_written) {
		rc = -EAGAIN;
		while (rc == -EAGAIN) {
			if (file->private_data == NULL) {
				/* file has been closed on us */
				FreeXid(xid);
			/* if we have gotten here we have written some data
			   and blocked, and the file has been freed on us while
			   we blocked so return what we managed to write */
				return total_written;
S
Steve French 已提交
902
			}
L
Linus Torvalds 已提交
903 904 905 906 907
			if (open_file->invalidHandle) {
				/* we could deadlock if we called
				   filemap_fdatawait from here so tell
				   reopen_file not to flush data to server
				   now */
J
Jeff Layton 已提交
908
				rc = cifs_reopen_file(open_file, false);
L
Linus Torvalds 已提交
909 910 911 912 913 914 915 916 917
				if (rc != 0)
					break;
			}

			rc = CIFSSMBWrite(xid, pTcon,
				open_file->netfid,
				min_t(const int, cifs_sb->wsize,
				      write_size - total_written),
				*poffset, &bytes_written,
918
				NULL, write_data + total_written, 0);
L
Linus Torvalds 已提交
919 920 921 922 923 924 925 926
		}
		if (rc || (bytes_written == 0)) {
			if (total_written)
				break;
			else {
				FreeXid(xid);
				return rc;
			}
927 928
		} else {
			cifs_update_eof(cifsi, *poffset, bytes_written);
L
Linus Torvalds 已提交
929
			*poffset += bytes_written;
930
		}
L
Linus Torvalds 已提交
931 932
	}

933
	cifs_stats_bytes_written(pTcon, total_written);
L
Linus Torvalds 已提交
934

S
Steve French 已提交
935
/* Do not update local mtime - server will set its actual value on write
J
Jiri Slaby 已提交
936 937 938 939 940 941 942
 *	inode->i_ctime = inode->i_mtime =
 * 		current_fs_time(inode->i_sb);*/
	if (total_written > 0) {
		spin_lock(&inode->i_lock);
		if (*poffset > inode->i_size)
			i_size_write(inode, *poffset);
		spin_unlock(&inode->i_lock);
L
Linus Torvalds 已提交
943
	}
J
Jiri Slaby 已提交
944 945
	mark_inode_dirty_sync(inode);

L
Linus Torvalds 已提交
946 947 948 949
	FreeXid(xid);
	return total_written;
}

950 951 952
static ssize_t cifs_write(struct cifsFileInfo *open_file,
			  const char *write_data, size_t write_size,
			  loff_t *poffset)
L
Linus Torvalds 已提交
953 954 955 956 957 958
{
	int rc = 0;
	unsigned int bytes_written = 0;
	unsigned int total_written;
	struct cifs_sb_info *cifs_sb;
	struct cifsTconInfo *pTcon;
959
	int xid;
960 961
	struct dentry *dentry = open_file->dentry;
	struct cifsInodeInfo *cifsi = CIFS_I(dentry->d_inode);
L
Linus Torvalds 已提交
962

963
	cifs_sb = CIFS_SB(dentry->d_sb);
L
Linus Torvalds 已提交
964

965
	cFYI(1, "write %zd bytes to offset %lld of %s", write_size,
966
	   *poffset, dentry->d_name.name);
L
Linus Torvalds 已提交
967

968
	pTcon = tlink_tcon(open_file->tlink);
969

L
Linus Torvalds 已提交
970 971 972 973 974 975 976 977 978
	xid = GetXid();

	for (total_written = 0; write_size > total_written;
	     total_written += bytes_written) {
		rc = -EAGAIN;
		while (rc == -EAGAIN) {
			if (open_file->invalidHandle) {
				/* we could deadlock if we called
				   filemap_fdatawait from here so tell
S
Steve French 已提交
979
				   reopen_file not to flush data to
L
Linus Torvalds 已提交
980
				   server now */
J
Jeff Layton 已提交
981
				rc = cifs_reopen_file(open_file, false);
L
Linus Torvalds 已提交
982 983 984
				if (rc != 0)
					break;
			}
S
Steve French 已提交
985 986
			if (experimEnabled || (pTcon->ses->server &&
				((pTcon->ses->server->secMode &
S
Steve French 已提交
987
				(SECMODE_SIGN_REQUIRED | SECMODE_SIGN_ENABLED))
S
Steve French 已提交
988
				== 0))) {
989 990 991
				struct kvec iov[2];
				unsigned int len;

992
				len = min((size_t)cifs_sb->wsize,
993 994 995 996 997
					  write_size - total_written);
				/* iov[0] is reserved for smb header */
				iov[1].iov_base = (char *)write_data +
						  total_written;
				iov[1].iov_len = len;
998
				rc = CIFSSMBWrite2(xid, pTcon,
999
						open_file->netfid, len,
1000
						*poffset, &bytes_written,
1001
						iov, 1, 0);
1002
			} else
1003 1004 1005 1006 1007 1008
				rc = CIFSSMBWrite(xid, pTcon,
					 open_file->netfid,
					 min_t(const int, cifs_sb->wsize,
					       write_size - total_written),
					 *poffset, &bytes_written,
					 write_data + total_written,
1009
					 NULL, 0);
L
Linus Torvalds 已提交
1010 1011 1012 1013 1014 1015 1016 1017
		}
		if (rc || (bytes_written == 0)) {
			if (total_written)
				break;
			else {
				FreeXid(xid);
				return rc;
			}
1018 1019
		} else {
			cifs_update_eof(cifsi, *poffset, bytes_written);
L
Linus Torvalds 已提交
1020
			*poffset += bytes_written;
1021
		}
L
Linus Torvalds 已提交
1022 1023
	}

1024
	cifs_stats_bytes_written(pTcon, total_written);
L
Linus Torvalds 已提交
1025

1026 1027 1028 1029 1030
	if (total_written > 0) {
		spin_lock(&dentry->d_inode->i_lock);
		if (*poffset > dentry->d_inode->i_size)
			i_size_write(dentry->d_inode, *poffset);
		spin_unlock(&dentry->d_inode->i_lock);
L
Linus Torvalds 已提交
1031
	}
1032
	mark_inode_dirty_sync(dentry->d_inode);
L
Linus Torvalds 已提交
1033 1034 1035 1036
	FreeXid(xid);
	return total_written;
}

1037 1038
struct cifsFileInfo *find_readable_file(struct cifsInodeInfo *cifs_inode,
					bool fsuid_only)
S
Steve French 已提交
1039 1040
{
	struct cifsFileInfo *open_file = NULL;
1041 1042 1043 1044 1045
	struct cifs_sb_info *cifs_sb = CIFS_SB(cifs_inode->vfs_inode.i_sb);

	/* only filter by fsuid on multiuser mounts */
	if (!(cifs_sb->mnt_cifs_flags & CIFS_MOUNT_MULTIUSER))
		fsuid_only = false;
S
Steve French 已提交
1046

1047
	spin_lock(&cifs_file_list_lock);
S
Steve French 已提交
1048 1049 1050 1051
	/* we could simply get the first_list_entry since write-only entries
	   are always at the end of the list but since the first entry might
	   have a close pending, we go through the whole list */
	list_for_each_entry(open_file, &cifs_inode->openFileList, flist) {
1052 1053
		if (fsuid_only && open_file->uid != current_fsuid())
			continue;
1054
		if (OPEN_FMODE(open_file->f_flags) & FMODE_READ) {
S
Steve French 已提交
1055 1056 1057
			if (!open_file->invalidHandle) {
				/* found a good file */
				/* lock it so it will not be closed on us */
1058
				cifsFileInfo_get(open_file);
1059
				spin_unlock(&cifs_file_list_lock);
S
Steve French 已提交
1060 1061 1062 1063 1064 1065 1066
				return open_file;
			} /* else might as well continue, and look for
			     another, or simply have the caller reopen it
			     again rather than trying to fix this handle */
		} else /* write only file */
			break; /* write only files are last so must be done */
	}
1067
	spin_unlock(&cifs_file_list_lock);
S
Steve French 已提交
1068 1069 1070
	return NULL;
}

1071 1072
struct cifsFileInfo *find_writable_file(struct cifsInodeInfo *cifs_inode,
					bool fsuid_only)
1073 1074
{
	struct cifsFileInfo *open_file;
1075
	struct cifs_sb_info *cifs_sb;
1076
	bool any_available = false;
1077
	int rc;
1078

1079 1080 1081 1082
	/* Having a null inode here (because mapping->host was set to zero by
	the VFS or MM) should not happen but we had reports of on oops (due to
	it being zero) during stress testcases so we need to check for it */

S
Steve French 已提交
1083
	if (cifs_inode == NULL) {
1084
		cERROR(1, "Null inode passed to cifs_writeable_file");
1085 1086 1087 1088
		dump_stack();
		return NULL;
	}

1089 1090
	cifs_sb = CIFS_SB(cifs_inode->vfs_inode.i_sb);

1091 1092 1093 1094
	/* only filter by fsuid on multiuser mounts */
	if (!(cifs_sb->mnt_cifs_flags & CIFS_MOUNT_MULTIUSER))
		fsuid_only = false;

1095
	spin_lock(&cifs_file_list_lock);
1096
refind_writable:
1097
	list_for_each_entry(open_file, &cifs_inode->openFileList, flist) {
1098 1099 1100
		if (!any_available && open_file->pid != current->tgid)
			continue;
		if (fsuid_only && open_file->uid != current_fsuid())
1101
			continue;
1102
		if (OPEN_FMODE(open_file->f_flags) & FMODE_WRITE) {
1103
			cifsFileInfo_get(open_file);
1104 1105 1106

			if (!open_file->invalidHandle) {
				/* found a good writable file */
1107
				spin_unlock(&cifs_file_list_lock);
1108 1109
				return open_file;
			}
S
Steve French 已提交
1110

1111
			spin_unlock(&cifs_file_list_lock);
1112

1113
			/* Had to unlock since following call can block */
J
Jeff Layton 已提交
1114
			rc = cifs_reopen_file(open_file, false);
1115 1116
			if (!rc)
				return open_file;
1117

1118
			/* if it fails, try another handle if possible */
1119
			cFYI(1, "wp failed on reopen file");
1120
			cifsFileInfo_put(open_file);
S
Steve French 已提交
1121

1122 1123
			spin_lock(&cifs_file_list_lock);

1124 1125 1126 1127 1128 1129 1130
			/* else we simply continue to the next entry. Thus
			   we do not loop on reopen errors.  If we
			   can not reopen the file, for example if we
			   reconnected to a server with another client
			   racing to delete or lock the file we would not
			   make progress if we restarted before the beginning
			   of the loop here. */
1131 1132
		}
	}
1133 1134 1135 1136 1137
	/* couldn't find useable FH with same pid, try any available */
	if (!any_available) {
		any_available = true;
		goto refind_writable;
	}
1138
	spin_unlock(&cifs_file_list_lock);
1139 1140 1141
	return NULL;
}

L
Linus Torvalds 已提交
1142 1143 1144 1145 1146 1147 1148 1149 1150
static int cifs_partialpagewrite(struct page *page, unsigned from, unsigned to)
{
	struct address_space *mapping = page->mapping;
	loff_t offset = (loff_t)page->index << PAGE_CACHE_SHIFT;
	char *write_data;
	int rc = -EFAULT;
	int bytes_written = 0;
	struct cifs_sb_info *cifs_sb;
	struct inode *inode;
1151
	struct cifsFileInfo *open_file;
L
Linus Torvalds 已提交
1152 1153 1154 1155 1156 1157 1158 1159 1160 1161 1162 1163 1164 1165 1166 1167 1168 1169 1170 1171 1172 1173 1174 1175

	if (!mapping || !mapping->host)
		return -EFAULT;

	inode = page->mapping->host;
	cifs_sb = CIFS_SB(inode->i_sb);

	offset += (loff_t)from;
	write_data = kmap(page);
	write_data += from;

	if ((to > PAGE_CACHE_SIZE) || (from > to)) {
		kunmap(page);
		return -EIO;
	}

	/* racing with truncate? */
	if (offset > mapping->host->i_size) {
		kunmap(page);
		return 0; /* don't care */
	}

	/* check to make sure that we are not extending the file */
	if (mapping->host->i_size - offset < (loff_t)to)
S
Steve French 已提交
1176
		to = (unsigned)(mapping->host->i_size - offset);
L
Linus Torvalds 已提交
1177

1178
	open_file = find_writable_file(CIFS_I(mapping->host), false);
1179
	if (open_file) {
1180 1181
		bytes_written = cifs_write(open_file, write_data,
					   to - from, &offset);
1182
		cifsFileInfo_put(open_file);
L
Linus Torvalds 已提交
1183
		/* Does mm or vfs already set times? */
1184
		inode->i_atime = inode->i_mtime = current_fs_time(inode->i_sb);
1185
		if ((bytes_written > 0) && (offset))
1186
			rc = 0;
1187 1188
		else if (bytes_written < 0)
			rc = bytes_written;
1189
	} else {
1190
		cFYI(1, "No writeable filehandles for inode");
L
Linus Torvalds 已提交
1191 1192 1193 1194 1195 1196 1197 1198
		rc = -EIO;
	}

	kunmap(page);
	return rc;
}

static int cifs_writepages(struct address_space *mapping,
1199
			   struct writeback_control *wbc)
L
Linus Torvalds 已提交
1200
{
1201 1202 1203 1204
	unsigned int bytes_to_write;
	unsigned int bytes_written;
	struct cifs_sb_info *cifs_sb;
	int done = 0;
1205
	pgoff_t end;
1206
	pgoff_t index;
S
Steve French 已提交
1207 1208
	int range_whole = 0;
	struct kvec *iov;
1209
	int len;
1210 1211 1212 1213
	int n_iov = 0;
	pgoff_t next;
	int nr_pages;
	__u64 offset = 0;
1214
	struct cifsFileInfo *open_file;
1215
	struct cifsTconInfo *tcon;
1216
	struct cifsInodeInfo *cifsi = CIFS_I(mapping->host);
1217 1218 1219 1220
	struct page *page;
	struct pagevec pvec;
	int rc = 0;
	int scanned = 0;
1221
	int xid;
L
Linus Torvalds 已提交
1222

1223
	cifs_sb = CIFS_SB(mapping->host->i_sb);
1224

1225 1226 1227 1228 1229 1230 1231
	/*
	 * If wsize is smaller that the page cache size, default to writing
	 * one page at a time via cifs_writepage
	 */
	if (cifs_sb->wsize < PAGE_CACHE_SIZE)
		return generic_writepages(mapping, wbc);

1232
	iov = kmalloc(32 * sizeof(struct kvec), GFP_KERNEL);
S
Steve French 已提交
1233
	if (iov == NULL)
1234 1235
		return generic_writepages(mapping, wbc);

1236
	/*
1237 1238 1239
	 * if there's no open file, then this is likely to fail too,
	 * but it'll at least handle the return. Maybe it should be
	 * a BUG() instead?
1240
	 */
1241
	open_file = find_writable_file(CIFS_I(mapping->host), false);
1242
	if (!open_file) {
1243
		kfree(iov);
1244 1245 1246
		return generic_writepages(mapping, wbc);
	}

1247
	tcon = tlink_tcon(open_file->tlink);
1248 1249 1250
	if (!experimEnabled && tcon->ses->server->secMode &
			(SECMODE_SIGN_REQUIRED | SECMODE_SIGN_ENABLED)) {
		cifsFileInfo_put(open_file);
D
Dan Carpenter 已提交
1251
		kfree(iov);
1252
		return generic_writepages(mapping, wbc);
1253
	}
1254
	cifsFileInfo_put(open_file);
1255

L
Linus Torvalds 已提交
1256 1257
	xid = GetXid();

1258
	pagevec_init(&pvec, 0);
1259
	if (wbc->range_cyclic) {
1260
		index = mapping->writeback_index; /* Start from prev offset */
1261 1262 1263 1264 1265 1266
		end = -1;
	} else {
		index = wbc->range_start >> PAGE_CACHE_SHIFT;
		end = wbc->range_end >> PAGE_CACHE_SHIFT;
		if (wbc->range_start == 0 && wbc->range_end == LLONG_MAX)
			range_whole = 1;
1267 1268 1269 1270 1271 1272 1273 1274 1275 1276 1277 1278 1279 1280 1281 1282 1283 1284 1285 1286 1287 1288 1289 1290 1291 1292 1293
		scanned = 1;
	}
retry:
	while (!done && (index <= end) &&
	       (nr_pages = pagevec_lookup_tag(&pvec, mapping, &index,
			PAGECACHE_TAG_DIRTY,
			min(end - index, (pgoff_t)PAGEVEC_SIZE - 1) + 1))) {
		int first;
		unsigned int i;

		first = -1;
		next = 0;
		n_iov = 0;
		bytes_to_write = 0;

		for (i = 0; i < nr_pages; i++) {
			page = pvec.pages[i];
			/*
			 * At this point we hold neither mapping->tree_lock nor
			 * lock on the page itself: the page may be truncated or
			 * invalidated (changing page->mapping to NULL), or even
			 * swizzled back from swapper_space to tmpfs file
			 * mapping
			 */

			if (first < 0)
				lock_page(page);
N
Nick Piggin 已提交
1294
			else if (!trylock_page(page))
1295 1296 1297 1298 1299 1300 1301
				break;

			if (unlikely(page->mapping != mapping)) {
				unlock_page(page);
				break;
			}

1302
			if (!wbc->range_cyclic && page->index > end) {
1303 1304 1305 1306 1307 1308 1309 1310 1311 1312 1313 1314 1315 1316 1317
				done = 1;
				unlock_page(page);
				break;
			}

			if (next && (page->index != next)) {
				/* Not next consecutive page */
				unlock_page(page);
				break;
			}

			if (wbc->sync_mode != WB_SYNC_NONE)
				wait_on_page_writeback(page);

			if (PageWriteback(page) ||
1318
					!clear_page_dirty_for_io(page)) {
1319 1320 1321
				unlock_page(page);
				break;
			}
1322

1323 1324 1325 1326 1327 1328
			/*
			 * This actually clears the dirty bit in the radix tree.
			 * See cifs_writepage() for more commentary.
			 */
			set_page_writeback(page);

1329 1330 1331
			if (page_offset(page) >= mapping->host->i_size) {
				done = 1;
				unlock_page(page);
1332
				end_page_writeback(page);
1333 1334 1335
				break;
			}

1336 1337 1338 1339 1340
			/*
			 * BB can we get rid of this?  pages are held by pvec
			 */
			page_cache_get(page);

1341 1342 1343
			len = min(mapping->host->i_size - page_offset(page),
				  (loff_t)PAGE_CACHE_SIZE);

1344 1345 1346
			/* reserve iov[0] for the smb header */
			n_iov++;
			iov[n_iov].iov_base = kmap(page);
1347 1348
			iov[n_iov].iov_len = len;
			bytes_to_write += len;
1349 1350 1351 1352 1353 1354 1355 1356 1357 1358

			if (first < 0) {
				first = i;
				offset = page_offset(page);
			}
			next = page->index + 1;
			if (bytes_to_write + PAGE_CACHE_SIZE > cifs_sb->wsize)
				break;
		}
		if (n_iov) {
1359
retry_write:
1360 1361
			open_file = find_writable_file(CIFS_I(mapping->host),
							false);
1362
			if (!open_file) {
1363
				cERROR(1, "No writable handles for inode");
1364
				rc = -EBADF;
S
Steve French 已提交
1365
			} else {
1366
				rc = CIFSSMBWrite2(xid, tcon, open_file->netfid,
1367 1368
						   bytes_to_write, offset,
						   &bytes_written, iov, n_iov,
1369
						   0);
1370
				cifsFileInfo_put(open_file);
1371
			}
1372

1373 1374 1375 1376 1377 1378 1379 1380 1381 1382 1383 1384 1385 1386 1387 1388 1389 1390 1391 1392 1393 1394 1395 1396 1397
			cFYI(1, "Write2 rc=%d, wrote=%u", rc, bytes_written);

			/*
			 * For now, treat a short write as if nothing got
			 * written. A zero length write however indicates
			 * ENOSPC or EFBIG. We have no way to know which
			 * though, so call it ENOSPC for now. EFBIG would
			 * get translated to AS_EIO anyway.
			 *
			 * FIXME: make it take into account the data that did
			 *	  get written
			 */
			if (rc == 0) {
				if (bytes_written == 0)
					rc = -ENOSPC;
				else if (bytes_written < bytes_to_write)
					rc = -EAGAIN;
			}

			/* retry on data-integrity flush */
			if (wbc->sync_mode == WB_SYNC_ALL && rc == -EAGAIN)
				goto retry_write;

			/* fix the stats and EOF */
			if (bytes_written > 0) {
1398
				cifs_stats_bytes_written(tcon, bytes_written);
1399
				cifs_update_eof(cifsi, offset, bytes_written);
1400
			}
1401

1402 1403
			for (i = 0; i < n_iov; i++) {
				page = pvec.pages[first + i];
1404 1405 1406 1407
				/* on retryable write error, redirty page */
				if (rc == -EAGAIN)
					redirty_page_for_writepage(wbc, page);
				else if (rc != 0)
1408
					SetPageError(page);
1409 1410
				kunmap(page);
				unlock_page(page);
1411
				end_page_writeback(page);
1412 1413
				page_cache_release(page);
			}
1414 1415 1416 1417 1418 1419

			if (rc != -EAGAIN)
				mapping_set_error(mapping, rc);
			else
				rc = 0;

1420 1421 1422
			if ((wbc->nr_to_write -= n_iov) <= 0)
				done = 1;
			index = next;
1423 1424 1425 1426
		} else
			/* Need to re-find the pages we skipped */
			index = pvec.pages[0]->index + 1;

1427 1428 1429 1430 1431 1432 1433 1434 1435 1436 1437
		pagevec_release(&pvec);
	}
	if (!scanned && !done) {
		/*
		 * We hit the last page and there is more work to be done: wrap
		 * back to the start of the file
		 */
		scanned = 1;
		index = 0;
		goto retry;
	}
1438
	if (wbc->range_cyclic || (range_whole && wbc->nr_to_write > 0))
1439 1440
		mapping->writeback_index = index;

L
Linus Torvalds 已提交
1441
	FreeXid(xid);
1442
	kfree(iov);
L
Linus Torvalds 已提交
1443 1444 1445
	return rc;
}

S
Steve French 已提交
1446
static int cifs_writepage(struct page *page, struct writeback_control *wbc)
L
Linus Torvalds 已提交
1447 1448 1449 1450 1451 1452 1453
{
	int rc = -EFAULT;
	int xid;

	xid = GetXid();
/* BB add check for wbc flags */
	page_cache_get(page);
S
Steve French 已提交
1454
	if (!PageUptodate(page))
1455
		cFYI(1, "ppw - page not up to date");
1456 1457 1458 1459 1460 1461 1462 1463 1464 1465 1466

	/*
	 * Set the "writeback" flag, and clear "dirty" in the radix tree.
	 *
	 * A writepage() implementation always needs to do either this,
	 * or re-dirty the page with "redirty_page_for_writepage()" in
	 * the case of a failure.
	 *
	 * Just unlocking the page will cause the radix tree tag-bits
	 * to fail to update with the state of the page correctly.
	 */
S
Steve French 已提交
1467
	set_page_writeback(page);
L
Linus Torvalds 已提交
1468 1469 1470
	rc = cifs_partialpagewrite(page, 0, PAGE_CACHE_SIZE);
	SetPageUptodate(page); /* BB add check for error and Clearuptodate? */
	unlock_page(page);
1471 1472
	end_page_writeback(page);
	page_cache_release(page);
L
Linus Torvalds 已提交
1473 1474 1475 1476
	FreeXid(xid);
	return rc;
}

N
Nick Piggin 已提交
1477 1478 1479
static int cifs_write_end(struct file *file, struct address_space *mapping,
			loff_t pos, unsigned len, unsigned copied,
			struct page *page, void *fsdata)
L
Linus Torvalds 已提交
1480
{
N
Nick Piggin 已提交
1481 1482
	int rc;
	struct inode *inode = mapping->host;
L
Linus Torvalds 已提交
1483

1484 1485
	cFYI(1, "write_end for page %p from pos %lld with %d bytes",
		 page, pos, copied);
N
Nick Piggin 已提交
1486

1487 1488 1489 1490 1491
	if (PageChecked(page)) {
		if (copied == len)
			SetPageUptodate(page);
		ClearPageChecked(page);
	} else if (!PageUptodate(page) && copied == PAGE_CACHE_SIZE)
N
Nick Piggin 已提交
1492
		SetPageUptodate(page);
S
Steve French 已提交
1493

L
Linus Torvalds 已提交
1494
	if (!PageUptodate(page)) {
N
Nick Piggin 已提交
1495 1496 1497 1498 1499
		char *page_data;
		unsigned offset = pos & (PAGE_CACHE_SIZE - 1);
		int xid;

		xid = GetXid();
L
Linus Torvalds 已提交
1500 1501 1502 1503 1504 1505
		/* this is probably better than directly calling
		   partialpage_write since in this function the file handle is
		   known which we might as well	leverage */
		/* BB check if anything else missing out of ppw
		   such as updating last write time */
		page_data = kmap(page);
1506 1507
		rc = cifs_write(file->private_data, page_data + offset,
				copied, &pos);
N
Nick Piggin 已提交
1508
		/* if (rc < 0) should we set writebehind rc? */
L
Linus Torvalds 已提交
1509
		kunmap(page);
N
Nick Piggin 已提交
1510 1511

		FreeXid(xid);
S
Steve French 已提交
1512
	} else {
N
Nick Piggin 已提交
1513 1514
		rc = copied;
		pos += copied;
L
Linus Torvalds 已提交
1515 1516 1517
		set_page_dirty(page);
	}

N
Nick Piggin 已提交
1518 1519 1520 1521 1522 1523 1524 1525 1526 1527
	if (rc > 0) {
		spin_lock(&inode->i_lock);
		if (pos > inode->i_size)
			i_size_write(inode, pos);
		spin_unlock(&inode->i_lock);
	}

	unlock_page(page);
	page_cache_release(page);

L
Linus Torvalds 已提交
1528 1529 1530
	return rc;
}

1531
int cifs_strict_fsync(struct file *file, int datasync)
L
Linus Torvalds 已提交
1532 1533 1534
{
	int xid;
	int rc = 0;
1535
	struct cifsTconInfo *tcon;
1536
	struct cifsFileInfo *smbfile = file->private_data;
1537
	struct inode *inode = file->f_path.dentry->d_inode;
1538
	struct cifs_sb_info *cifs_sb = CIFS_SB(inode->i_sb);
L
Linus Torvalds 已提交
1539 1540 1541

	xid = GetXid();

1542
	cFYI(1, "Sync file - name: %s datasync: 0x%x",
1543
		file->f_path.dentry->d_name.name, datasync);
1544

1545 1546
	if (!CIFS_I(inode)->clientCanCacheRead)
		cifs_invalidate_mapping(inode);
1547

1548 1549 1550 1551 1552 1553 1554 1555 1556 1557 1558 1559 1560 1561 1562 1563 1564 1565 1566 1567 1568 1569 1570 1571
	tcon = tlink_tcon(smbfile->tlink);
	if (!(cifs_sb->mnt_cifs_flags & CIFS_MOUNT_NOSSYNC))
		rc = CIFSSMBFlush(xid, tcon, smbfile->netfid);

	FreeXid(xid);
	return rc;
}

int cifs_fsync(struct file *file, int datasync)
{
	int xid;
	int rc = 0;
	struct cifsTconInfo *tcon;
	struct cifsFileInfo *smbfile = file->private_data;
	struct cifs_sb_info *cifs_sb = CIFS_SB(file->f_path.dentry->d_sb);

	xid = GetXid();

	cFYI(1, "Sync file - name: %s datasync: 0x%x",
		file->f_path.dentry->d_name.name, datasync);

	tcon = tlink_tcon(smbfile->tlink);
	if (!(cifs_sb->mnt_cifs_flags & CIFS_MOUNT_NOSSYNC))
		rc = CIFSSMBFlush(xid, tcon, smbfile->netfid);
1572

L
Linus Torvalds 已提交
1573 1574 1575 1576
	FreeXid(xid);
	return rc;
}

1577
/* static void cifs_sync_page(struct page *page)
L
Linus Torvalds 已提交
1578 1579 1580 1581 1582 1583 1584
{
	struct address_space *mapping;
	struct inode *inode;
	unsigned long index = page->index;
	unsigned int rpages = 0;
	int rc = 0;

1585
	cFYI(1, "sync page %p", page);
L
Linus Torvalds 已提交
1586 1587 1588 1589 1590
	mapping = page->mapping;
	if (!mapping)
		return 0;
	inode = mapping->host;
	if (!inode)
1591
		return; */
L
Linus Torvalds 已提交
1592

S
Steve French 已提交
1593
/*	fill in rpages then
L
Linus Torvalds 已提交
1594 1595
	result = cifs_pagein_inode(inode, index, rpages); */ /* BB finish */

1596
/*	cFYI(1, "rpages is %d for sync page of Index %ld", rpages, index);
L
Linus Torvalds 已提交
1597

1598
#if 0
L
Linus Torvalds 已提交
1599 1600 1601
	if (rc < 0)
		return rc;
	return 0;
1602
#endif
L
Linus Torvalds 已提交
1603 1604 1605 1606 1607 1608
} */

/*
 * As file closes, flush all cached write data for this inode checking
 * for write behind errors.
 */
1609
int cifs_flush(struct file *file, fl_owner_t id)
L
Linus Torvalds 已提交
1610
{
S
Steve French 已提交
1611
	struct inode *inode = file->f_path.dentry->d_inode;
L
Linus Torvalds 已提交
1612 1613
	int rc = 0;

1614
	if (file->f_mode & FMODE_WRITE)
1615
		rc = filemap_write_and_wait(inode->i_mapping);
1616

1617
	cFYI(1, "Flush inode %p file %p rc %d", inode, file, rc);
L
Linus Torvalds 已提交
1618 1619 1620 1621 1622 1623 1624 1625 1626 1627 1628 1629 1630 1631 1632 1633 1634 1635 1636 1637

	return rc;
}

ssize_t cifs_user_read(struct file *file, char __user *read_data,
	size_t read_size, loff_t *poffset)
{
	int rc = -EACCES;
	unsigned int bytes_read = 0;
	unsigned int total_read = 0;
	unsigned int current_read_size;
	struct cifs_sb_info *cifs_sb;
	struct cifsTconInfo *pTcon;
	int xid;
	struct cifsFileInfo *open_file;
	char *smb_read_data;
	char __user *current_offset;
	struct smb_com_read_rsp *pSMBr;

	xid = GetXid();
1638
	cifs_sb = CIFS_SB(file->f_path.dentry->d_sb);
L
Linus Torvalds 已提交
1639 1640

	if (file->private_data == NULL) {
1641
		rc = -EBADF;
L
Linus Torvalds 已提交
1642
		FreeXid(xid);
1643
		return rc;
L
Linus Torvalds 已提交
1644
	}
1645
	open_file = file->private_data;
1646
	pTcon = tlink_tcon(open_file->tlink);
L
Linus Torvalds 已提交
1647

S
Steve French 已提交
1648
	if ((file->f_flags & O_ACCMODE) == O_WRONLY)
1649
		cFYI(1, "attempting read on write only file instance");
S
Steve French 已提交
1650

L
Linus Torvalds 已提交
1651 1652 1653
	for (total_read = 0, current_offset = read_data;
	     read_size > total_read;
	     total_read += bytes_read, current_offset += bytes_read) {
S
Steve French 已提交
1654
		current_read_size = min_t(const int, read_size - total_read,
L
Linus Torvalds 已提交
1655 1656 1657 1658
					  cifs_sb->rsize);
		rc = -EAGAIN;
		smb_read_data = NULL;
		while (rc == -EAGAIN) {
1659
			int buf_type = CIFS_NO_BUFFER;
1660
			if (open_file->invalidHandle) {
J
Jeff Layton 已提交
1661
				rc = cifs_reopen_file(open_file, true);
L
Linus Torvalds 已提交
1662 1663 1664
				if (rc != 0)
					break;
			}
1665
			rc = CIFSSMBRead(xid, pTcon,
1666 1667 1668 1669
					 open_file->netfid,
					 current_read_size, *poffset,
					 &bytes_read, &smb_read_data,
					 &buf_type);
L
Linus Torvalds 已提交
1670 1671
			pSMBr = (struct smb_com_read_rsp *)smb_read_data;
			if (smb_read_data) {
1672 1673 1674 1675
				if (copy_to_user(current_offset,
						smb_read_data +
						4 /* RFC1001 length field */ +
						le16_to_cpu(pSMBr->DataOffset),
S
Steve French 已提交
1676
						bytes_read))
1677 1678
					rc = -EFAULT;

S
Steve French 已提交
1679
				if (buf_type == CIFS_SMALL_BUFFER)
1680
					cifs_small_buf_release(smb_read_data);
S
Steve French 已提交
1681
				else if (buf_type == CIFS_LARGE_BUFFER)
1682
					cifs_buf_release(smb_read_data);
L
Linus Torvalds 已提交
1683 1684 1685 1686 1687 1688 1689 1690 1691 1692 1693
				smb_read_data = NULL;
			}
		}
		if (rc || (bytes_read == 0)) {
			if (total_read) {
				break;
			} else {
				FreeXid(xid);
				return rc;
			}
		} else {
1694
			cifs_stats_bytes_read(pTcon, bytes_read);
L
Linus Torvalds 已提交
1695 1696 1697 1698 1699 1700 1701 1702 1703 1704 1705 1706 1707 1708 1709 1710 1711 1712 1713 1714
			*poffset += bytes_read;
		}
	}
	FreeXid(xid);
	return total_read;
}


static ssize_t cifs_read(struct file *file, char *read_data, size_t read_size,
	loff_t *poffset)
{
	int rc = -EACCES;
	unsigned int bytes_read = 0;
	unsigned int total_read;
	unsigned int current_read_size;
	struct cifs_sb_info *cifs_sb;
	struct cifsTconInfo *pTcon;
	int xid;
	char *current_offset;
	struct cifsFileInfo *open_file;
1715
	int buf_type = CIFS_NO_BUFFER;
L
Linus Torvalds 已提交
1716 1717

	xid = GetXid();
1718
	cifs_sb = CIFS_SB(file->f_path.dentry->d_sb);
L
Linus Torvalds 已提交
1719 1720

	if (file->private_data == NULL) {
1721
		rc = -EBADF;
L
Linus Torvalds 已提交
1722
		FreeXid(xid);
1723
		return rc;
L
Linus Torvalds 已提交
1724
	}
1725
	open_file = file->private_data;
1726
	pTcon = tlink_tcon(open_file->tlink);
L
Linus Torvalds 已提交
1727 1728

	if ((file->f_flags & O_ACCMODE) == O_WRONLY)
1729
		cFYI(1, "attempting read on write only file instance");
L
Linus Torvalds 已提交
1730

S
Steve French 已提交
1731
	for (total_read = 0, current_offset = read_data;
L
Linus Torvalds 已提交
1732 1733 1734 1735
	     read_size > total_read;
	     total_read += bytes_read, current_offset += bytes_read) {
		current_read_size = min_t(const int, read_size - total_read,
					  cifs_sb->rsize);
1736 1737
		/* For windows me and 9x we do not want to request more
		than it negotiated since it will refuse the read then */
S
Steve French 已提交
1738
		if ((pTcon->ses) &&
1739 1740 1741 1742
			!(pTcon->ses->capabilities & CAP_LARGE_FILES)) {
			current_read_size = min_t(const int, current_read_size,
					pTcon->ses->server->maxBuf - 128);
		}
L
Linus Torvalds 已提交
1743 1744
		rc = -EAGAIN;
		while (rc == -EAGAIN) {
1745
			if (open_file->invalidHandle) {
J
Jeff Layton 已提交
1746
				rc = cifs_reopen_file(open_file, true);
L
Linus Torvalds 已提交
1747 1748 1749
				if (rc != 0)
					break;
			}
1750
			rc = CIFSSMBRead(xid, pTcon,
1751 1752 1753 1754
					 open_file->netfid,
					 current_read_size, *poffset,
					 &bytes_read, &current_offset,
					 &buf_type);
L
Linus Torvalds 已提交
1755 1756 1757 1758 1759 1760 1761 1762 1763
		}
		if (rc || (bytes_read == 0)) {
			if (total_read) {
				break;
			} else {
				FreeXid(xid);
				return rc;
			}
		} else {
1764
			cifs_stats_bytes_read(pTcon, total_read);
L
Linus Torvalds 已提交
1765 1766 1767 1768 1769 1770 1771
			*poffset += bytes_read;
		}
	}
	FreeXid(xid);
	return total_read;
}

1772 1773 1774 1775 1776 1777 1778 1779 1780 1781 1782 1783 1784 1785 1786
int cifs_file_strict_mmap(struct file *file, struct vm_area_struct *vma)
{
	int rc, xid;
	struct inode *inode = file->f_path.dentry->d_inode;

	xid = GetXid();

	if (!CIFS_I(inode)->clientCanCacheRead)
		cifs_invalidate_mapping(inode);

	rc = generic_file_mmap(file, vma);
	FreeXid(xid);
	return rc;
}

L
Linus Torvalds 已提交
1787 1788 1789 1790 1791
int cifs_file_mmap(struct file *file, struct vm_area_struct *vma)
{
	int rc, xid;

	xid = GetXid();
J
Jeff Layton 已提交
1792
	rc = cifs_revalidate_file(file);
L
Linus Torvalds 已提交
1793
	if (rc) {
1794
		cFYI(1, "Validation prior to mmap failed, error=%d", rc);
L
Linus Torvalds 已提交
1795 1796 1797 1798 1799 1800 1801 1802 1803
		FreeXid(xid);
		return rc;
	}
	rc = generic_file_mmap(file, vma);
	FreeXid(xid);
	return rc;
}


S
Steve French 已提交
1804
static void cifs_copy_cache_pages(struct address_space *mapping,
N
Nick Piggin 已提交
1805
	struct list_head *pages, int bytes_read, char *data)
L
Linus Torvalds 已提交
1806 1807 1808 1809 1810 1811 1812 1813 1814 1815 1816
{
	struct page *page;
	char *target;

	while (bytes_read > 0) {
		if (list_empty(pages))
			break;

		page = list_entry(pages->prev, struct page, lru);
		list_del(&page->lru);

N
Nick Piggin 已提交
1817
		if (add_to_page_cache_lru(page, mapping, page->index,
L
Linus Torvalds 已提交
1818 1819
				      GFP_KERNEL)) {
			page_cache_release(page);
1820
			cFYI(1, "Add page cache failed");
1821 1822
			data += PAGE_CACHE_SIZE;
			bytes_read -= PAGE_CACHE_SIZE;
L
Linus Torvalds 已提交
1823 1824
			continue;
		}
J
Jeff Layton 已提交
1825
		page_cache_release(page);
L
Linus Torvalds 已提交
1826

S
Steve French 已提交
1827
		target = kmap_atomic(page, KM_USER0);
L
Linus Torvalds 已提交
1828 1829 1830 1831

		if (PAGE_CACHE_SIZE > bytes_read) {
			memcpy(target, data, bytes_read);
			/* zero the tail end of this partial page */
S
Steve French 已提交
1832
			memset(target + bytes_read, 0,
L
Linus Torvalds 已提交
1833 1834 1835 1836 1837 1838 1839 1840 1841 1842 1843 1844
			       PAGE_CACHE_SIZE - bytes_read);
			bytes_read = 0;
		} else {
			memcpy(target, data, PAGE_CACHE_SIZE);
			bytes_read -= PAGE_CACHE_SIZE;
		}
		kunmap_atomic(target, KM_USER0);

		flush_dcache_page(page);
		SetPageUptodate(page);
		unlock_page(page);
		data += PAGE_CACHE_SIZE;
1845 1846 1847

		/* add page to FS-Cache */
		cifs_readpage_to_fscache(mapping->host, page);
L
Linus Torvalds 已提交
1848 1849 1850 1851 1852 1853 1854 1855 1856 1857 1858 1859 1860
	}
	return;
}

static int cifs_readpages(struct file *file, struct address_space *mapping,
	struct list_head *page_list, unsigned num_pages)
{
	int rc = -EACCES;
	int xid;
	loff_t offset;
	struct page *page;
	struct cifs_sb_info *cifs_sb;
	struct cifsTconInfo *pTcon;
S
Steve French 已提交
1861
	unsigned int bytes_read = 0;
S
Steve French 已提交
1862
	unsigned int read_size, i;
L
Linus Torvalds 已提交
1863 1864 1865
	char *smb_read_data = NULL;
	struct smb_com_read_rsp *pSMBr;
	struct cifsFileInfo *open_file;
1866
	int buf_type = CIFS_NO_BUFFER;
L
Linus Torvalds 已提交
1867 1868 1869

	xid = GetXid();
	if (file->private_data == NULL) {
1870
		rc = -EBADF;
L
Linus Torvalds 已提交
1871
		FreeXid(xid);
1872
		return rc;
L
Linus Torvalds 已提交
1873
	}
1874
	open_file = file->private_data;
1875
	cifs_sb = CIFS_SB(file->f_path.dentry->d_sb);
1876
	pTcon = tlink_tcon(open_file->tlink);
1877

1878 1879 1880 1881 1882 1883 1884 1885 1886
	/*
	 * Reads as many pages as possible from fscache. Returns -ENOBUFS
	 * immediately if the cookie is negative
	 */
	rc = cifs_readpages_from_fscache(mapping->host, mapping, page_list,
					 &num_pages);
	if (rc == 0)
		goto read_complete;

1887
	cFYI(DBG2, "rpages: num pages %d", num_pages);
L
Linus Torvalds 已提交
1888 1889 1890 1891 1892 1893 1894 1895 1896 1897 1898 1899 1900
	for (i = 0; i < num_pages; ) {
		unsigned contig_pages;
		struct page *tmp_page;
		unsigned long expected_index;

		if (list_empty(page_list))
			break;

		page = list_entry(page_list->prev, struct page, lru);
		offset = (loff_t)page->index << PAGE_CACHE_SHIFT;

		/* count adjacent pages that we will read into */
		contig_pages = 0;
S
Steve French 已提交
1901
		expected_index =
L
Linus Torvalds 已提交
1902
			list_entry(page_list->prev, struct page, lru)->index;
S
Steve French 已提交
1903
		list_for_each_entry_reverse(tmp_page, page_list, lru) {
L
Linus Torvalds 已提交
1904 1905 1906 1907
			if (tmp_page->index == expected_index) {
				contig_pages++;
				expected_index++;
			} else
S
Steve French 已提交
1908
				break;
L
Linus Torvalds 已提交
1909 1910 1911 1912 1913 1914 1915 1916 1917 1918 1919
		}
		if (contig_pages + i >  num_pages)
			contig_pages = num_pages - i;

		/* for reads over a certain size could initiate async
		   read ahead */

		read_size = contig_pages * PAGE_CACHE_SIZE;
		/* Read size needs to be in multiples of one page */
		read_size = min_t(const unsigned int, read_size,
				  cifs_sb->rsize & PAGE_CACHE_MASK);
1920 1921
		cFYI(DBG2, "rpages: read size 0x%x  contiguous pages %d",
				read_size, contig_pages);
L
Linus Torvalds 已提交
1922 1923
		rc = -EAGAIN;
		while (rc == -EAGAIN) {
1924
			if (open_file->invalidHandle) {
J
Jeff Layton 已提交
1925
				rc = cifs_reopen_file(open_file, true);
L
Linus Torvalds 已提交
1926 1927 1928 1929
				if (rc != 0)
					break;
			}

1930
			rc = CIFSSMBRead(xid, pTcon,
1931 1932 1933 1934
					 open_file->netfid,
					 read_size, offset,
					 &bytes_read, &smb_read_data,
					 &buf_type);
1935
			/* BB more RC checks ? */
S
Steve French 已提交
1936
			if (rc == -EAGAIN) {
L
Linus Torvalds 已提交
1937
				if (smb_read_data) {
S
Steve French 已提交
1938
					if (buf_type == CIFS_SMALL_BUFFER)
1939
						cifs_small_buf_release(smb_read_data);
S
Steve French 已提交
1940
					else if (buf_type == CIFS_LARGE_BUFFER)
1941
						cifs_buf_release(smb_read_data);
L
Linus Torvalds 已提交
1942 1943 1944 1945 1946
					smb_read_data = NULL;
				}
			}
		}
		if ((rc < 0) || (smb_read_data == NULL)) {
1947
			cFYI(1, "Read error in readpages: %d", rc);
L
Linus Torvalds 已提交
1948 1949
			break;
		} else if (bytes_read > 0) {
1950
			task_io_account_read(bytes_read);
L
Linus Torvalds 已提交
1951 1952 1953
			pSMBr = (struct smb_com_read_rsp *)smb_read_data;
			cifs_copy_cache_pages(mapping, page_list, bytes_read,
				smb_read_data + 4 /* RFC1001 hdr */ +
N
Nick Piggin 已提交
1954
				le16_to_cpu(pSMBr->DataOffset));
L
Linus Torvalds 已提交
1955 1956

			i +=  bytes_read >> PAGE_CACHE_SHIFT;
1957
			cifs_stats_bytes_read(pTcon, bytes_read);
S
Steve French 已提交
1958
			if ((bytes_read & PAGE_CACHE_MASK) != bytes_read) {
L
Linus Torvalds 已提交
1959 1960
				i++; /* account for partial page */

S
Steve French 已提交
1961
				/* server copy of file can have smaller size
L
Linus Torvalds 已提交
1962
				   than client */
S
Steve French 已提交
1963 1964
				/* BB do we need to verify this common case ?
				   this case is ok - if we are at server EOF
L
Linus Torvalds 已提交
1965 1966
				   we will hit it on next read */

O
OGAWA Hirofumi 已提交
1967
				/* break; */
L
Linus Torvalds 已提交
1968 1969
			}
		} else {
1970
			cFYI(1, "No bytes read (%d) at offset %lld . "
1971
				"Cleaning remaining pages from readahead list",
1972
				bytes_read, offset);
S
Steve French 已提交
1973
			/* BB turn off caching and do new lookup on
L
Linus Torvalds 已提交
1974 1975 1976 1977
			   file size at server? */
			break;
		}
		if (smb_read_data) {
S
Steve French 已提交
1978
			if (buf_type == CIFS_SMALL_BUFFER)
1979
				cifs_small_buf_release(smb_read_data);
S
Steve French 已提交
1980
			else if (buf_type == CIFS_LARGE_BUFFER)
1981
				cifs_buf_release(smb_read_data);
L
Linus Torvalds 已提交
1982 1983 1984 1985 1986 1987 1988
			smb_read_data = NULL;
		}
		bytes_read = 0;
	}

/* need to free smb_read_data buf before exit */
	if (smb_read_data) {
S
Steve French 已提交
1989
		if (buf_type == CIFS_SMALL_BUFFER)
1990
			cifs_small_buf_release(smb_read_data);
S
Steve French 已提交
1991
		else if (buf_type == CIFS_LARGE_BUFFER)
1992
			cifs_buf_release(smb_read_data);
L
Linus Torvalds 已提交
1993
		smb_read_data = NULL;
S
Steve French 已提交
1994
	}
L
Linus Torvalds 已提交
1995

1996
read_complete:
L
Linus Torvalds 已提交
1997 1998 1999 2000 2001 2002 2003 2004 2005 2006
	FreeXid(xid);
	return rc;
}

static int cifs_readpage_worker(struct file *file, struct page *page,
	loff_t *poffset)
{
	char *read_data;
	int rc;

2007 2008 2009 2010 2011
	/* Is the page cached? */
	rc = cifs_readpage_from_fscache(file->f_path.dentry->d_inode, page);
	if (rc == 0)
		goto read_complete;

L
Linus Torvalds 已提交
2012 2013 2014
	page_cache_get(page);
	read_data = kmap(page);
	/* for reads over a certain size could initiate async read ahead */
S
Steve French 已提交
2015

L
Linus Torvalds 已提交
2016
	rc = cifs_read(file, read_data, PAGE_CACHE_SIZE, poffset);
S
Steve French 已提交
2017

L
Linus Torvalds 已提交
2018 2019 2020
	if (rc < 0)
		goto io_error;
	else
2021
		cFYI(1, "Bytes read %d", rc);
S
Steve French 已提交
2022

2023 2024
	file->f_path.dentry->d_inode->i_atime =
		current_fs_time(file->f_path.dentry->d_inode->i_sb);
S
Steve French 已提交
2025

L
Linus Torvalds 已提交
2026 2027 2028 2029 2030
	if (PAGE_CACHE_SIZE > rc)
		memset(read_data + rc, 0, PAGE_CACHE_SIZE - rc);

	flush_dcache_page(page);
	SetPageUptodate(page);
2031 2032 2033 2034

	/* send this page to the cache */
	cifs_readpage_to_fscache(file->f_path.dentry->d_inode, page);

L
Linus Torvalds 已提交
2035
	rc = 0;
S
Steve French 已提交
2036

L
Linus Torvalds 已提交
2037
io_error:
S
Steve French 已提交
2038
	kunmap(page);
L
Linus Torvalds 已提交
2039
	page_cache_release(page);
2040 2041

read_complete:
L
Linus Torvalds 已提交
2042 2043 2044 2045 2046 2047 2048 2049 2050 2051 2052 2053
	return rc;
}

static int cifs_readpage(struct file *file, struct page *page)
{
	loff_t offset = (loff_t)page->index << PAGE_CACHE_SHIFT;
	int rc = -EACCES;
	int xid;

	xid = GetXid();

	if (file->private_data == NULL) {
2054
		rc = -EBADF;
L
Linus Torvalds 已提交
2055
		FreeXid(xid);
2056
		return rc;
L
Linus Torvalds 已提交
2057 2058
	}

2059 2060
	cFYI(1, "readpage %p at offset %d 0x%x\n",
		 page, (int)offset, (int)offset);
L
Linus Torvalds 已提交
2061 2062 2063 2064 2065 2066 2067 2068 2069

	rc = cifs_readpage_worker(file, page, &offset);

	unlock_page(page);

	FreeXid(xid);
	return rc;
}

2070 2071 2072 2073
static int is_inode_writable(struct cifsInodeInfo *cifs_inode)
{
	struct cifsFileInfo *open_file;

2074
	spin_lock(&cifs_file_list_lock);
2075
	list_for_each_entry(open_file, &cifs_inode->openFileList, flist) {
2076
		if (OPEN_FMODE(open_file->f_flags) & FMODE_WRITE) {
2077
			spin_unlock(&cifs_file_list_lock);
2078 2079 2080
			return 1;
		}
	}
2081
	spin_unlock(&cifs_file_list_lock);
2082 2083 2084
	return 0;
}

L
Linus Torvalds 已提交
2085 2086 2087
/* We do not want to update the file size from server for inodes
   open for write - to avoid races with writepage extending
   the file - in the future we could consider allowing
S
Steve French 已提交
2088
   refreshing the inode only on increases in the file size
L
Linus Torvalds 已提交
2089 2090
   but this is tricky to do without racing with writebehind
   page caching in the current Linux kernel design */
2091
bool is_size_safe_to_change(struct cifsInodeInfo *cifsInode, __u64 end_of_file)
L
Linus Torvalds 已提交
2092
{
2093
	if (!cifsInode)
2094
		return true;
2095

2096 2097
	if (is_inode_writable(cifsInode)) {
		/* This inode is open for write at least once */
2098 2099 2100
		struct cifs_sb_info *cifs_sb;

		cifs_sb = CIFS_SB(cifsInode->vfs_inode.i_sb);
S
Steve French 已提交
2101
		if (cifs_sb->mnt_cifs_flags & CIFS_MOUNT_DIRECT_IO) {
S
Steve French 已提交
2102
			/* since no page cache to corrupt on directio
2103
			we can change size safely */
2104
			return true;
2105 2106
		}

S
Steve French 已提交
2107
		if (i_size_read(&cifsInode->vfs_inode) < end_of_file)
2108
			return true;
2109

2110
		return false;
2111
	} else
2112
		return true;
L
Linus Torvalds 已提交
2113 2114
}

N
Nick Piggin 已提交
2115 2116 2117
static int cifs_write_begin(struct file *file, struct address_space *mapping,
			loff_t pos, unsigned len, unsigned flags,
			struct page **pagep, void **fsdata)
L
Linus Torvalds 已提交
2118
{
N
Nick Piggin 已提交
2119 2120
	pgoff_t index = pos >> PAGE_CACHE_SHIFT;
	loff_t offset = pos & (PAGE_CACHE_SIZE - 1);
2121 2122 2123 2124
	loff_t page_start = pos & PAGE_MASK;
	loff_t i_size;
	struct page *page;
	int rc = 0;
N
Nick Piggin 已提交
2125

2126
	cFYI(1, "write_begin from %lld len %d", (long long)pos, len);
N
Nick Piggin 已提交
2127

2128
	page = grab_cache_page_write_begin(mapping, index, flags);
2129 2130 2131 2132
	if (!page) {
		rc = -ENOMEM;
		goto out;
	}
2133

2134 2135
	if (PageUptodate(page))
		goto out;
2136

2137 2138 2139 2140 2141 2142 2143
	/*
	 * If we write a full page it will be up to date, no need to read from
	 * the server. If the write is short, we'll end up doing a sync write
	 * instead.
	 */
	if (len == PAGE_CACHE_SIZE)
		goto out;
2144

2145 2146 2147 2148 2149 2150 2151 2152 2153 2154 2155 2156 2157 2158 2159 2160 2161 2162 2163 2164 2165 2166 2167
	/*
	 * optimize away the read when we have an oplock, and we're not
	 * expecting to use any of the data we'd be reading in. That
	 * is, when the page lies beyond the EOF, or straddles the EOF
	 * and the write will cover all of the existing data.
	 */
	if (CIFS_I(mapping->host)->clientCanCacheRead) {
		i_size = i_size_read(mapping->host);
		if (page_start >= i_size ||
		    (offset == 0 && (pos + len) >= i_size)) {
			zero_user_segments(page, 0, offset,
					   offset + len,
					   PAGE_CACHE_SIZE);
			/*
			 * PageChecked means that the parts of the page
			 * to which we're not writing are considered up
			 * to date. Once the data is copied to the
			 * page, it can be set uptodate.
			 */
			SetPageChecked(page);
			goto out;
		}
	}
N
Nick Piggin 已提交
2168

2169 2170 2171 2172 2173 2174 2175
	if ((file->f_flags & O_ACCMODE) != O_WRONLY) {
		/*
		 * might as well read a page, it is fast enough. If we get
		 * an error, we don't need to return it. cifs_write_end will
		 * do a sync write instead since PG_uptodate isn't set.
		 */
		cifs_readpage_worker(file, page, &page_start);
2176 2177 2178 2179
	} else {
		/* we could try using another file handle if there is one -
		   but how would we lock it to prevent close of that handle
		   racing with this read? In any case
N
Nick Piggin 已提交
2180
		   this will be written out by write_end so is fine */
L
Linus Torvalds 已提交
2181
	}
2182 2183 2184
out:
	*pagep = page;
	return rc;
L
Linus Torvalds 已提交
2185 2186
}

2187 2188 2189 2190 2191 2192 2193 2194 2195 2196 2197 2198 2199 2200 2201 2202
static int cifs_release_page(struct page *page, gfp_t gfp)
{
	if (PagePrivate(page))
		return 0;

	return cifs_fscache_release_page(page, gfp);
}

static void cifs_invalidate_page(struct page *page, unsigned long offset)
{
	struct cifsInodeInfo *cifsi = CIFS_I(page->mapping->host);

	if (offset == 0)
		cifs_fscache_invalidate_page(page, &cifsi->vfs_inode);
}

2203
void cifs_oplock_break(struct work_struct *work)
2204 2205 2206
{
	struct cifsFileInfo *cfile = container_of(work, struct cifsFileInfo,
						  oplock_break);
2207
	struct inode *inode = cfile->dentry->d_inode;
2208
	struct cifsInodeInfo *cinode = CIFS_I(inode);
2209
	int rc = 0;
2210 2211

	if (inode && S_ISREG(inode->i_mode)) {
S
Steve French 已提交
2212
		if (cinode->clientCanCacheRead)
2213
			break_lease(inode, O_RDONLY);
S
Steve French 已提交
2214
		else
2215
			break_lease(inode, O_WRONLY);
2216 2217
		rc = filemap_fdatawrite(inode->i_mapping);
		if (cinode->clientCanCacheRead == 0) {
2218 2219
			rc = filemap_fdatawait(inode->i_mapping);
			mapping_set_error(inode->i_mapping, rc);
2220 2221
			invalidate_remote_inode(inode);
		}
2222
		cFYI(1, "Oplock flush inode %p rc %d", inode, rc);
2223 2224 2225 2226 2227 2228 2229 2230
	}

	/*
	 * releasing stale oplock after recent reconnect of smb session using
	 * a now incorrect file handle is not a data integrity issue but do
	 * not bother sending an oplock release if session to server still is
	 * disconnected since oplock already released by the server
	 */
2231
	if (!cfile->oplock_break_cancelled) {
2232
		rc = CIFSSMBLock(0, tlink_tcon(cfile->tlink), cfile->netfid, 0,
2233 2234
				 0, 0, 0, LOCKING_ANDX_OPLOCK_RELEASE, false,
				 cinode->clientCanCacheRead ? 1 : 0);
2235
		cFYI(1, "Oplock release rc = %d", rc);
2236
	}
2237 2238 2239 2240

	/*
	 * We might have kicked in before is_valid_oplock_break()
	 * finished grabbing reference for us.  Make sure it's done by
2241
	 * waiting for cifs_file_list_lock.
2242
	 */
2243 2244
	spin_lock(&cifs_file_list_lock);
	spin_unlock(&cifs_file_list_lock);
2245 2246

	cifs_oplock_break_put(cfile);
2247 2248
}

2249
/* must be called while holding cifs_file_list_lock */
2250
void cifs_oplock_break_get(struct cifsFileInfo *cfile)
2251
{
2252
	cifs_sb_active(cfile->dentry->d_sb);
2253 2254 2255
	cifsFileInfo_get(cfile);
}

2256
void cifs_oplock_break_put(struct cifsFileInfo *cfile)
2257
{
2258 2259
	struct super_block *sb = cfile->dentry->d_sb;

2260
	cifsFileInfo_put(cfile);
2261
	cifs_sb_deactive(sb);
2262 2263
}

2264
const struct address_space_operations cifs_addr_ops = {
L
Linus Torvalds 已提交
2265 2266 2267
	.readpage = cifs_readpage,
	.readpages = cifs_readpages,
	.writepage = cifs_writepage,
2268
	.writepages = cifs_writepages,
N
Nick Piggin 已提交
2269 2270
	.write_begin = cifs_write_begin,
	.write_end = cifs_write_end,
L
Linus Torvalds 已提交
2271
	.set_page_dirty = __set_page_dirty_nobuffers,
2272 2273
	.releasepage = cifs_release_page,
	.invalidatepage = cifs_invalidate_page,
L
Linus Torvalds 已提交
2274 2275 2276
	/* .sync_page = cifs_sync_page, */
	/* .direct_IO = */
};
D
Dave Kleikamp 已提交
2277 2278 2279 2280 2281 2282

/*
 * cifs_readpages requires the server to support a buffer large enough to
 * contain the header plus one complete page of data.  Otherwise, we need
 * to leave cifs_readpages out of the address space operations.
 */
2283
const struct address_space_operations cifs_addr_ops_smallbuf = {
D
Dave Kleikamp 已提交
2284 2285 2286
	.readpage = cifs_readpage,
	.writepage = cifs_writepage,
	.writepages = cifs_writepages,
N
Nick Piggin 已提交
2287 2288
	.write_begin = cifs_write_begin,
	.write_end = cifs_write_end,
D
Dave Kleikamp 已提交
2289
	.set_page_dirty = __set_page_dirty_nobuffers,
2290 2291
	.releasepage = cifs_release_page,
	.invalidatepage = cifs_invalidate_page,
D
Dave Kleikamp 已提交
2292 2293 2294
	/* .sync_page = cifs_sync_page, */
	/* .direct_IO = */
};