proc.c 16.9 KB
Newer Older
L
Linus Torvalds 已提交
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44
/*
 *  linux/fs/nfs/proc.c
 *
 *  Copyright (C) 1992, 1993, 1994  Rick Sladkey
 *
 *  OS-independent nfs remote procedure call functions
 *
 *  Tuned by Alan Cox <A.Cox@swansea.ac.uk> for >3K buffers
 *  so at last we can have decent(ish) throughput off a 
 *  Sun server.
 *
 *  Coding optimized and cleaned up by Florian La Roche.
 *  Note: Error returns are optimized for NFS_OK, which isn't translated via
 *  nfs_stat_to_errno(), but happens to be already the right return code.
 *
 *  Also, the code currently doesn't check the size of the packet, when
 *  it decodes the packet.
 *
 *  Feel free to fix it and mail me the diffs if it worries you.
 *
 *  Completely rewritten to support the new RPC call interface;
 *  rewrote and moved the entire XDR stuff to xdr.c
 *  --Olaf Kirch June 1996
 *
 *  The code below initializes all auto variables explicitly, otherwise
 *  it will fail to work as a module (gcc generates a memset call for an
 *  incomplete struct).
 */

#include <linux/types.h>
#include <linux/param.h>
#include <linux/slab.h>
#include <linux/time.h>
#include <linux/mm.h>
#include <linux/errno.h>
#include <linux/string.h>
#include <linux/in.h>
#include <linux/pagemap.h>
#include <linux/sunrpc/clnt.h>
#include <linux/nfs.h>
#include <linux/nfs2.h>
#include <linux/nfs_fs.h>
#include <linux/nfs_page.h>
#include <linux/lockd/bind.h>
D
David Howells 已提交
45
#include "internal.h"
L
Linus Torvalds 已提交
46 47 48 49 50 51 52 53 54 55 56 57

#define NFSDBG_FACILITY		NFSDBG_PROC

/*
 * Bare-bones access to getattr: this is for nfs_read_super.
 */
static int
nfs_proc_get_root(struct nfs_server *server, struct nfs_fh *fhandle,
		  struct nfs_fsinfo *info)
{
	struct nfs_fattr *fattr = info->fattr;
	struct nfs2_fsstat fsinfo;
C
Chuck Lever 已提交
58 59 60 61 62
	struct rpc_message msg = {
		.rpc_proc	= &nfs_procedures[NFSPROC_GETATTR],
		.rpc_argp	= fhandle,
		.rpc_resp	= fattr,
	};
L
Linus Torvalds 已提交
63 64
	int status;

65
	dprintk("%s: call getattr\n", __func__);
66
	nfs_fattr_init(fattr);
E
EG Keizer 已提交
67 68 69 70
	status = rpc_call_sync(server->client, &msg, 0);
	/* Retry with default authentication if different */
	if (status && server->nfs_client->cl_rpcclient != server->client)
		status = rpc_call_sync(server->nfs_client->cl_rpcclient, &msg, 0);
71
	dprintk("%s: reply getattr: %d\n", __func__, status);
L
Linus Torvalds 已提交
72 73
	if (status)
		return status;
74
	dprintk("%s: call statfs\n", __func__);
C
Chuck Lever 已提交
75 76
	msg.rpc_proc = &nfs_procedures[NFSPROC_STATFS];
	msg.rpc_resp = &fsinfo;
E
EG Keizer 已提交
77 78 79 80
	status = rpc_call_sync(server->client, &msg, 0);
	/* Retry with default authentication if different */
	if (status && server->nfs_client->cl_rpcclient != server->client)
		status = rpc_call_sync(server->nfs_client->cl_rpcclient, &msg, 0);
81
	dprintk("%s: reply statfs: %d\n", __func__, status);
L
Linus Torvalds 已提交
82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102
	if (status)
		return status;
	info->rtmax  = NFS_MAXDATA;
	info->rtpref = fsinfo.tsize;
	info->rtmult = fsinfo.bsize;
	info->wtmax  = NFS_MAXDATA;
	info->wtpref = fsinfo.tsize;
	info->wtmult = fsinfo.bsize;
	info->dtpref = fsinfo.tsize;
	info->maxfilesize = 0x7FFFFFFF;
	info->lease_time = 0;
	return 0;
}

/*
 * One function for each procedure in the NFS protocol.
 */
static int
nfs_proc_getattr(struct nfs_server *server, struct nfs_fh *fhandle,
		struct nfs_fattr *fattr)
{
C
Chuck Lever 已提交
103 104 105 106 107
	struct rpc_message msg = {
		.rpc_proc	= &nfs_procedures[NFSPROC_GETATTR],
		.rpc_argp	= fhandle,
		.rpc_resp	= fattr,
	};
L
Linus Torvalds 已提交
108 109 110
	int	status;

	dprintk("NFS call  getattr\n");
111
	nfs_fattr_init(fattr);
C
Chuck Lever 已提交
112
	status = rpc_call_sync(server->client, &msg, 0);
L
Linus Torvalds 已提交
113 114 115 116 117 118 119 120 121 122 123 124 125
	dprintk("NFS reply getattr: %d\n", status);
	return status;
}

static int
nfs_proc_setattr(struct dentry *dentry, struct nfs_fattr *fattr,
		 struct iattr *sattr)
{
	struct inode *inode = dentry->d_inode;
	struct nfs_sattrargs	arg = { 
		.fh	= NFS_FH(inode),
		.sattr	= sattr
	};
C
Chuck Lever 已提交
126 127 128 129 130
	struct rpc_message msg = {
		.rpc_proc	= &nfs_procedures[NFSPROC_SETATTR],
		.rpc_argp	= &arg,
		.rpc_resp	= fattr,
	};
L
Linus Torvalds 已提交
131 132
	int	status;

133 134 135
	/* Mask out the non-modebit related stuff from attr->ia_mode */
	sattr->ia_mode &= S_IALLUGO;

L
Linus Torvalds 已提交
136
	dprintk("NFS call  setattr\n");
137 138
	if (sattr->ia_valid & ATTR_FILE)
		msg.rpc_cred = nfs_file_cred(sattr->ia_file);
139
	nfs_fattr_init(fattr);
C
Chuck Lever 已提交
140
	status = rpc_call_sync(NFS_CLIENT(inode), &msg, 0);
141 142
	if (status == 0)
		nfs_setattr_update_inode(inode, sattr);
L
Linus Torvalds 已提交
143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159
	dprintk("NFS reply setattr: %d\n", status);
	return status;
}

static int
nfs_proc_lookup(struct inode *dir, struct qstr *name,
		struct nfs_fh *fhandle, struct nfs_fattr *fattr)
{
	struct nfs_diropargs	arg = {
		.fh		= NFS_FH(dir),
		.name		= name->name,
		.len		= name->len
	};
	struct nfs_diropok	res = {
		.fh		= fhandle,
		.fattr		= fattr
	};
C
Chuck Lever 已提交
160 161 162 163 164
	struct rpc_message msg = {
		.rpc_proc	= &nfs_procedures[NFSPROC_LOOKUP],
		.rpc_argp	= &arg,
		.rpc_resp	= &res,
	};
L
Linus Torvalds 已提交
165 166 167
	int			status;

	dprintk("NFS call  lookup %s\n", name->name);
168
	nfs_fattr_init(fattr);
C
Chuck Lever 已提交
169
	status = rpc_call_sync(NFS_CLIENT(dir), &msg, 0);
L
Linus Torvalds 已提交
170 171 172 173 174 175 176 177 178 179 180 181 182
	dprintk("NFS reply lookup: %d\n", status);
	return status;
}

static int nfs_proc_readlink(struct inode *inode, struct page *page,
		unsigned int pgbase, unsigned int pglen)
{
	struct nfs_readlinkargs	args = {
		.fh		= NFS_FH(inode),
		.pgbase		= pgbase,
		.pglen		= pglen,
		.pages		= &page
	};
C
Chuck Lever 已提交
183 184 185 186
	struct rpc_message msg = {
		.rpc_proc	= &nfs_procedures[NFSPROC_READLINK],
		.rpc_argp	= &args,
	};
L
Linus Torvalds 已提交
187 188 189
	int			status;

	dprintk("NFS call  readlink\n");
C
Chuck Lever 已提交
190
	status = rpc_call_sync(NFS_CLIENT(inode), &msg, 0);
L
Linus Torvalds 已提交
191 192 193 194 195 196
	dprintk("NFS reply readlink: %d\n", status);
	return status;
}

static int
nfs_proc_create(struct inode *dir, struct dentry *dentry, struct iattr *sattr,
197
		int flags, struct nameidata *nd)
L
Linus Torvalds 已提交
198 199 200 201 202 203 204 205 206 207 208 209 210
{
	struct nfs_fh		fhandle;
	struct nfs_fattr	fattr;
	struct nfs_createargs	arg = {
		.fh		= NFS_FH(dir),
		.name		= dentry->d_name.name,
		.len		= dentry->d_name.len,
		.sattr		= sattr
	};
	struct nfs_diropok	res = {
		.fh		= &fhandle,
		.fattr		= &fattr
	};
C
Chuck Lever 已提交
211 212 213 214 215
	struct rpc_message msg = {
		.rpc_proc	= &nfs_procedures[NFSPROC_CREATE],
		.rpc_argp	= &arg,
		.rpc_resp	= &res,
	};
L
Linus Torvalds 已提交
216 217
	int			status;

218
	nfs_fattr_init(&fattr);
L
Linus Torvalds 已提交
219
	dprintk("NFS call  create %s\n", dentry->d_name.name);
C
Chuck Lever 已提交
220
	status = rpc_call_sync(NFS_CLIENT(dir), &msg, 0);
221
	nfs_mark_for_revalidate(dir);
L
Linus Torvalds 已提交
222 223 224 225 226 227 228 229 230 231 232 233 234 235 236 237 238 239 240 241 242 243 244 245 246
	if (status == 0)
		status = nfs_instantiate(dentry, &fhandle, &fattr);
	dprintk("NFS reply create: %d\n", status);
	return status;
}

/*
 * In NFSv2, mknod is grafted onto the create call.
 */
static int
nfs_proc_mknod(struct inode *dir, struct dentry *dentry, struct iattr *sattr,
	       dev_t rdev)
{
	struct nfs_fh fhandle;
	struct nfs_fattr fattr;
	struct nfs_createargs	arg = {
		.fh		= NFS_FH(dir),
		.name		= dentry->d_name.name,
		.len		= dentry->d_name.len,
		.sattr		= sattr
	};
	struct nfs_diropok	res = {
		.fh		= &fhandle,
		.fattr		= &fattr
	};
C
Chuck Lever 已提交
247 248 249 250 251
	struct rpc_message msg = {
		.rpc_proc	= &nfs_procedures[NFSPROC_CREATE],
		.rpc_argp	= &arg,
		.rpc_resp	= &res,
	};
L
Linus Torvalds 已提交
252 253 254 255 256 257 258 259 260 261 262 263 264
	int status, mode;

	dprintk("NFS call  mknod %s\n", dentry->d_name.name);

	mode = sattr->ia_mode;
	if (S_ISFIFO(mode)) {
		sattr->ia_mode = (mode & ~S_IFMT) | S_IFCHR;
		sattr->ia_valid &= ~ATTR_SIZE;
	} else if (S_ISCHR(mode) || S_ISBLK(mode)) {
		sattr->ia_valid |= ATTR_SIZE;
		sattr->ia_size = new_encode_dev(rdev);/* get out your barf bag */
	}

265
	nfs_fattr_init(&fattr);
C
Chuck Lever 已提交
266
	status = rpc_call_sync(NFS_CLIENT(dir), &msg, 0);
267
	nfs_mark_for_revalidate(dir);
L
Linus Torvalds 已提交
268 269 270

	if (status == -EINVAL && S_ISFIFO(mode)) {
		sattr->ia_mode = mode;
271
		nfs_fattr_init(&fattr);
C
Chuck Lever 已提交
272
		status = rpc_call_sync(NFS_CLIENT(dir), &msg, 0);
L
Linus Torvalds 已提交
273 274 275 276 277 278 279 280 281 282
	}
	if (status == 0)
		status = nfs_instantiate(dentry, &fhandle, &fattr);
	dprintk("NFS reply mknod: %d\n", status);
	return status;
}
  
static int
nfs_proc_remove(struct inode *dir, struct qstr *name)
{
283 284 285 286
	struct nfs_removeargs arg = {
		.fh = NFS_FH(dir),
		.name.len = name->len,
		.name.name = name->name,
L
Linus Torvalds 已提交
287
	};
288 289 290
	struct rpc_message msg = { 
		.rpc_proc = &nfs_procedures[NFSPROC_REMOVE],
		.rpc_argp = &arg,
L
Linus Torvalds 已提交
291 292 293 294 295
	};
	int			status;

	dprintk("NFS call  remove %s\n", name->name);
	status = rpc_call_sync(NFS_CLIENT(dir), &msg, 0);
296
	nfs_mark_for_revalidate(dir);
L
Linus Torvalds 已提交
297 298 299 300 301

	dprintk("NFS reply remove: %d\n", status);
	return status;
}

302 303
static void
nfs_proc_unlink_setup(struct rpc_message *msg, struct inode *dir)
L
Linus Torvalds 已提交
304 305 306 307
{
	msg->rpc_proc = &nfs_procedures[NFSPROC_REMOVE];
}

308
static int nfs_proc_unlink_done(struct rpc_task *task, struct inode *dir)
L
Linus Torvalds 已提交
309
{
310 311
	nfs_mark_for_revalidate(dir);
	return 1;
L
Linus Torvalds 已提交
312 313 314 315 316 317 318 319 320 321 322 323 324 325
}

static int
nfs_proc_rename(struct inode *old_dir, struct qstr *old_name,
		struct inode *new_dir, struct qstr *new_name)
{
	struct nfs_renameargs	arg = {
		.fromfh		= NFS_FH(old_dir),
		.fromname	= old_name->name,
		.fromlen	= old_name->len,
		.tofh		= NFS_FH(new_dir),
		.toname		= new_name->name,
		.tolen		= new_name->len
	};
C
Chuck Lever 已提交
326 327 328 329
	struct rpc_message msg = {
		.rpc_proc	= &nfs_procedures[NFSPROC_RENAME],
		.rpc_argp	= &arg,
	};
L
Linus Torvalds 已提交
330 331 332
	int			status;

	dprintk("NFS call  rename %s -> %s\n", old_name->name, new_name->name);
C
Chuck Lever 已提交
333
	status = rpc_call_sync(NFS_CLIENT(old_dir), &msg, 0);
334 335
	nfs_mark_for_revalidate(old_dir);
	nfs_mark_for_revalidate(new_dir);
L
Linus Torvalds 已提交
336 337 338 339 340 341 342 343 344 345 346 347 348
	dprintk("NFS reply rename: %d\n", status);
	return status;
}

static int
nfs_proc_link(struct inode *inode, struct inode *dir, struct qstr *name)
{
	struct nfs_linkargs	arg = {
		.fromfh		= NFS_FH(inode),
		.tofh		= NFS_FH(dir),
		.toname		= name->name,
		.tolen		= name->len
	};
C
Chuck Lever 已提交
349 350 351 352
	struct rpc_message msg = {
		.rpc_proc	= &nfs_procedures[NFSPROC_LINK],
		.rpc_argp	= &arg,
	};
L
Linus Torvalds 已提交
353 354 355
	int			status;

	dprintk("NFS call  link %s\n", name->name);
C
Chuck Lever 已提交
356
	status = rpc_call_sync(NFS_CLIENT(inode), &msg, 0);
357
	nfs_mark_for_revalidate(inode);
358
	nfs_mark_for_revalidate(dir);
L
Linus Torvalds 已提交
359 360 361 362 363
	dprintk("NFS reply link: %d\n", status);
	return status;
}

static int
364 365
nfs_proc_symlink(struct inode *dir, struct dentry *dentry, struct page *page,
		 unsigned int len, struct iattr *sattr)
L
Linus Torvalds 已提交
366
{
367 368
	struct nfs_fh fhandle;
	struct nfs_fattr fattr;
L
Linus Torvalds 已提交
369 370
	struct nfs_symlinkargs	arg = {
		.fromfh		= NFS_FH(dir),
371 372
		.fromname	= dentry->d_name.name,
		.fromlen	= dentry->d_name.len,
373 374
		.pages		= &page,
		.pathlen	= len,
L
Linus Torvalds 已提交
375 376
		.sattr		= sattr
	};
C
Chuck Lever 已提交
377 378 379 380
	struct rpc_message msg = {
		.rpc_proc	= &nfs_procedures[NFSPROC_SYMLINK],
		.rpc_argp	= &arg,
	};
L
Linus Torvalds 已提交
381 382
	int			status;

383
	if (len > NFS2_MAXPATHLEN)
L
Linus Torvalds 已提交
384
		return -ENAMETOOLONG;
385

386 387
	dprintk("NFS call  symlink %s\n", dentry->d_name.name);

C
Chuck Lever 已提交
388
	status = rpc_call_sync(NFS_CLIENT(dir), &msg, 0);
389
	nfs_mark_for_revalidate(dir);
390 391 392 393 394 395 396 397 398 399 400 401

	/*
	 * V2 SYMLINK requests don't return any attributes.  Setting the
	 * filehandle size to zero indicates to nfs_instantiate that it
	 * should fill in the data with a LOOKUP call on the wire.
	 */
	if (status == 0) {
		nfs_fattr_init(&fattr);
		fhandle.size = 0;
		status = nfs_instantiate(dentry, &fhandle, &fattr);
	}

L
Linus Torvalds 已提交
402 403 404 405 406 407 408 409 410 411 412 413 414 415 416 417 418 419 420
	dprintk("NFS reply symlink: %d\n", status);
	return status;
}

static int
nfs_proc_mkdir(struct inode *dir, struct dentry *dentry, struct iattr *sattr)
{
	struct nfs_fh fhandle;
	struct nfs_fattr fattr;
	struct nfs_createargs	arg = {
		.fh		= NFS_FH(dir),
		.name		= dentry->d_name.name,
		.len		= dentry->d_name.len,
		.sattr		= sattr
	};
	struct nfs_diropok	res = {
		.fh		= &fhandle,
		.fattr		= &fattr
	};
C
Chuck Lever 已提交
421 422 423 424 425
	struct rpc_message msg = {
		.rpc_proc	= &nfs_procedures[NFSPROC_MKDIR],
		.rpc_argp	= &arg,
		.rpc_resp	= &res,
	};
L
Linus Torvalds 已提交
426 427 428
	int			status;

	dprintk("NFS call  mkdir %s\n", dentry->d_name.name);
429
	nfs_fattr_init(&fattr);
C
Chuck Lever 已提交
430
	status = rpc_call_sync(NFS_CLIENT(dir), &msg, 0);
431
	nfs_mark_for_revalidate(dir);
L
Linus Torvalds 已提交
432 433 434 435 436 437 438 439 440 441 442 443 444 445
	if (status == 0)
		status = nfs_instantiate(dentry, &fhandle, &fattr);
	dprintk("NFS reply mkdir: %d\n", status);
	return status;
}

static int
nfs_proc_rmdir(struct inode *dir, struct qstr *name)
{
	struct nfs_diropargs	arg = {
		.fh		= NFS_FH(dir),
		.name		= name->name,
		.len		= name->len
	};
C
Chuck Lever 已提交
446 447 448 449
	struct rpc_message msg = {
		.rpc_proc	= &nfs_procedures[NFSPROC_RMDIR],
		.rpc_argp	= &arg,
	};
L
Linus Torvalds 已提交
450 451 452
	int			status;

	dprintk("NFS call  rmdir %s\n", name->name);
C
Chuck Lever 已提交
453
	status = rpc_call_sync(NFS_CLIENT(dir), &msg, 0);
454
	nfs_mark_for_revalidate(dir);
L
Linus Torvalds 已提交
455 456 457 458 459 460 461 462 463 464 465 466 467 468 469 470 471 472 473 474
	dprintk("NFS reply rmdir: %d\n", status);
	return status;
}

/*
 * The READDIR implementation is somewhat hackish - we pass a temporary
 * buffer to the encode function, which installs it in the receive
 * the receive iovec. The decode function just parses the reply to make
 * sure it is syntactically correct; the entries itself are decoded
 * from nfs_readdir by calling the decode_entry function directly.
 */
static int
nfs_proc_readdir(struct dentry *dentry, struct rpc_cred *cred,
		 u64 cookie, struct page *page, unsigned int count, int plus)
{
	struct inode		*dir = dentry->d_inode;
	struct nfs_readdirargs	arg = {
		.fh		= NFS_FH(dir),
		.cookie		= cookie,
		.count		= count,
C
Chuck Lever 已提交
475
		.pages		= &page,
L
Linus Torvalds 已提交
476 477 478 479
	};
	struct rpc_message	msg = {
		.rpc_proc	= &nfs_procedures[NFSPROC_READDIR],
		.rpc_argp	= &arg,
C
Chuck Lever 已提交
480
		.rpc_cred	= cred,
L
Linus Torvalds 已提交
481 482 483 484 485 486
	};
	int			status;

	dprintk("NFS call  readdir %d\n", (unsigned int)cookie);
	status = rpc_call_sync(NFS_CLIENT(dir), &msg, 0);

487 488
	nfs_invalidate_atime(dir);

L
Linus Torvalds 已提交
489 490 491 492 493 494 495 496 497
	dprintk("NFS reply readdir: %d\n", status);
	return status;
}

static int
nfs_proc_statfs(struct nfs_server *server, struct nfs_fh *fhandle,
			struct nfs_fsstat *stat)
{
	struct nfs2_fsstat fsinfo;
C
Chuck Lever 已提交
498 499 500 501 502
	struct rpc_message msg = {
		.rpc_proc	= &nfs_procedures[NFSPROC_STATFS],
		.rpc_argp	= fhandle,
		.rpc_resp	= &fsinfo,
	};
L
Linus Torvalds 已提交
503 504 505
	int	status;

	dprintk("NFS call  statfs\n");
506
	nfs_fattr_init(stat->fattr);
C
Chuck Lever 已提交
507
	status = rpc_call_sync(server->client, &msg, 0);
L
Linus Torvalds 已提交
508 509 510 511 512 513 514 515 516 517 518 519 520 521 522 523 524 525
	dprintk("NFS reply statfs: %d\n", status);
	if (status)
		goto out;
	stat->tbytes = (u64)fsinfo.blocks * fsinfo.bsize;
	stat->fbytes = (u64)fsinfo.bfree  * fsinfo.bsize;
	stat->abytes = (u64)fsinfo.bavail * fsinfo.bsize;
	stat->tfiles = 0;
	stat->ffiles = 0;
	stat->afiles = 0;
out:
	return status;
}

static int
nfs_proc_fsinfo(struct nfs_server *server, struct nfs_fh *fhandle,
			struct nfs_fsinfo *info)
{
	struct nfs2_fsstat fsinfo;
C
Chuck Lever 已提交
526 527 528 529 530
	struct rpc_message msg = {
		.rpc_proc	= &nfs_procedures[NFSPROC_STATFS],
		.rpc_argp	= fhandle,
		.rpc_resp	= &fsinfo,
	};
L
Linus Torvalds 已提交
531 532 533
	int	status;

	dprintk("NFS call  fsinfo\n");
534
	nfs_fattr_init(info->fattr);
C
Chuck Lever 已提交
535
	status = rpc_call_sync(server->client, &msg, 0);
L
Linus Torvalds 已提交
536 537 538 539 540 541 542 543 544 545 546 547 548 549 550 551 552 553 554 555 556 557 558 559 560
	dprintk("NFS reply fsinfo: %d\n", status);
	if (status)
		goto out;
	info->rtmax  = NFS_MAXDATA;
	info->rtpref = fsinfo.tsize;
	info->rtmult = fsinfo.bsize;
	info->wtmax  = NFS_MAXDATA;
	info->wtpref = fsinfo.tsize;
	info->wtmult = fsinfo.bsize;
	info->dtpref = fsinfo.tsize;
	info->maxfilesize = 0x7FFFFFFF;
	info->lease_time = 0;
out:
	return status;
}

static int
nfs_proc_pathconf(struct nfs_server *server, struct nfs_fh *fhandle,
		  struct nfs_pathconf *info)
{
	info->max_link = 0;
	info->max_namelen = NFS2_MAXNAMLEN;
	return 0;
}

T
Trond Myklebust 已提交
561
static int nfs_read_done(struct rpc_task *task, struct nfs_read_data *data)
L
Linus Torvalds 已提交
562
{
563
	nfs_invalidate_atime(data->inode);
L
Linus Torvalds 已提交
564 565 566 567 568 569 570 571
	if (task->tk_status >= 0) {
		nfs_refresh_inode(data->inode, data->res.fattr);
		/* Emulate the eof flag, which isn't normally needed in NFSv2
		 * as it is guaranteed to always return the file attributes
		 */
		if (data->args.offset + data->args.count >= data->res.fattr->size)
			data->res.eof = 1;
	}
T
Trond Myklebust 已提交
572
	return 0;
L
Linus Torvalds 已提交
573 574
}

575
static void nfs_proc_read_setup(struct nfs_read_data *data, struct rpc_message *msg)
L
Linus Torvalds 已提交
576
{
577
	msg->rpc_proc = &nfs_procedures[NFSPROC_READ];
L
Linus Torvalds 已提交
578 579
}

580
static int nfs_write_done(struct rpc_task *task, struct nfs_write_data *data)
L
Linus Torvalds 已提交
581 582
{
	if (task->tk_status >= 0)
583
		nfs_post_op_update_inode_force_wcc(data->inode, data->res.fattr);
584
	return 0;
L
Linus Torvalds 已提交
585 586
}

587
static void nfs_proc_write_setup(struct nfs_write_data *data, struct rpc_message *msg)
L
Linus Torvalds 已提交
588 589 590
{
	/* Note: NFSv2 ignores @stable and always uses NFS_FILE_SYNC */
	data->args.stable = NFS_FILE_SYNC;
591
	msg->rpc_proc = &nfs_procedures[NFSPROC_WRITE];
L
Linus Torvalds 已提交
592 593 594
}

static void
595
nfs_proc_commit_setup(struct nfs_write_data *data, struct rpc_message *msg)
L
Linus Torvalds 已提交
596 597 598 599 600 601 602
{
	BUG();
}

static int
nfs_proc_lock(struct file *filp, int cmd, struct file_lock *fl)
{
603 604 605
	struct inode *inode = filp->f_path.dentry->d_inode;

	return nlmclnt_proc(NFS_SERVER(inode)->nlm_host, cmd, fl);
L
Linus Torvalds 已提交
606 607
}

608 609 610 611 612 613 614 615 616 617 618 619 620 621 622 623 624 625 626 627 628 629 630
/* Helper functions for NFS lock bounds checking */
#define NFS_LOCK32_OFFSET_MAX ((__s32)0x7fffffffUL)
static int nfs_lock_check_bounds(const struct file_lock *fl)
{
	__s32 start, end;

	start = (__s32)fl->fl_start;
	if ((loff_t)start != fl->fl_start)
		goto out_einval;

	if (fl->fl_end != OFFSET_MAX) {
		end = (__s32)fl->fl_end;
		if ((loff_t)end != fl->fl_end)
			goto out_einval;
	} else
		end = NFS_LOCK32_OFFSET_MAX;

	if (start < 0 || start > end)
		goto out_einval;
	return 0;
out_einval:
	return -EINVAL;
}
L
Linus Torvalds 已提交
631

D
David Howells 已提交
632
const struct nfs_rpc_ops nfs_v2_clientops = {
L
Linus Torvalds 已提交
633 634 635
	.version	= 2,		       /* protocol version */
	.dentry_ops	= &nfs_dentry_operations,
	.dir_inode_ops	= &nfs_dir_inode_operations,
636
	.file_inode_ops	= &nfs_file_inode_operations,
L
Linus Torvalds 已提交
637 638 639 640 641 642 643 644 645 646 647 648 649 650 651 652 653 654 655 656 657 658
	.getroot	= nfs_proc_get_root,
	.getattr	= nfs_proc_getattr,
	.setattr	= nfs_proc_setattr,
	.lookup		= nfs_proc_lookup,
	.access		= NULL,		       /* access */
	.readlink	= nfs_proc_readlink,
	.create		= nfs_proc_create,
	.remove		= nfs_proc_remove,
	.unlink_setup	= nfs_proc_unlink_setup,
	.unlink_done	= nfs_proc_unlink_done,
	.rename		= nfs_proc_rename,
	.link		= nfs_proc_link,
	.symlink	= nfs_proc_symlink,
	.mkdir		= nfs_proc_mkdir,
	.rmdir		= nfs_proc_rmdir,
	.readdir	= nfs_proc_readdir,
	.mknod		= nfs_proc_mknod,
	.statfs		= nfs_proc_statfs,
	.fsinfo		= nfs_proc_fsinfo,
	.pathconf	= nfs_proc_pathconf,
	.decode_dirent	= nfs_decode_dirent,
	.read_setup	= nfs_proc_read_setup,
T
Trond Myklebust 已提交
659
	.read_done	= nfs_read_done,
L
Linus Torvalds 已提交
660
	.write_setup	= nfs_proc_write_setup,
661
	.write_done	= nfs_write_done,
L
Linus Torvalds 已提交
662 663
	.commit_setup	= nfs_proc_commit_setup,
	.lock		= nfs_proc_lock,
664
	.lock_check_bounds = nfs_lock_check_bounds,
T
Trond Myklebust 已提交
665
	.close_context	= nfs_close_context,
L
Linus Torvalds 已提交
666
};