]>
Commit | Line | Data |
---|---|---|
1da177e4 LT |
1 | /* |
2 | * linux/fs/nfs/proc.c | |
3 | * | |
4 | * Copyright (C) 1992, 1993, 1994 Rick Sladkey | |
5 | * | |
6 | * OS-independent nfs remote procedure call functions | |
7 | * | |
8 | * Tuned by Alan Cox <[email protected]> for >3K buffers | |
9 | * so at last we can have decent(ish) throughput off a | |
10 | * Sun server. | |
11 | * | |
12 | * Coding optimized and cleaned up by Florian La Roche. | |
13 | * Note: Error returns are optimized for NFS_OK, which isn't translated via | |
14 | * nfs_stat_to_errno(), but happens to be already the right return code. | |
15 | * | |
16 | * Also, the code currently doesn't check the size of the packet, when | |
17 | * it decodes the packet. | |
18 | * | |
19 | * Feel free to fix it and mail me the diffs if it worries you. | |
20 | * | |
21 | * Completely rewritten to support the new RPC call interface; | |
22 | * rewrote and moved the entire XDR stuff to xdr.c | |
23 | * --Olaf Kirch June 1996 | |
24 | * | |
25 | * The code below initializes all auto variables explicitly, otherwise | |
26 | * it will fail to work as a module (gcc generates a memset call for an | |
27 | * incomplete struct). | |
28 | */ | |
29 | ||
30 | #include <linux/types.h> | |
31 | #include <linux/param.h> | |
1da177e4 LT |
32 | #include <linux/time.h> |
33 | #include <linux/mm.h> | |
1da177e4 LT |
34 | #include <linux/errno.h> |
35 | #include <linux/string.h> | |
36 | #include <linux/in.h> | |
37 | #include <linux/pagemap.h> | |
38 | #include <linux/sunrpc/clnt.h> | |
39 | #include <linux/nfs.h> | |
40 | #include <linux/nfs2.h> | |
41 | #include <linux/nfs_fs.h> | |
42 | #include <linux/nfs_page.h> | |
43 | #include <linux/lockd/bind.h> | |
d310310c | 44 | #include <linux/freezer.h> |
f7b422b1 | 45 | #include "internal.h" |
1da177e4 LT |
46 | |
47 | #define NFSDBG_FACILITY NFSDBG_PROC | |
48 | ||
1da177e4 LT |
49 | /* |
50 | * Bare-bones access to getattr: this is for nfs_read_super. | |
51 | */ | |
52 | static int | |
53 | nfs_proc_get_root(struct nfs_server *server, struct nfs_fh *fhandle, | |
54 | struct nfs_fsinfo *info) | |
55 | { | |
56 | struct nfs_fattr *fattr = info->fattr; | |
57 | struct nfs2_fsstat fsinfo; | |
dead28da CL |
58 | struct rpc_message msg = { |
59 | .rpc_proc = &nfs_procedures[NFSPROC_GETATTR], | |
60 | .rpc_argp = fhandle, | |
61 | .rpc_resp = fattr, | |
62 | }; | |
1da177e4 LT |
63 | int status; |
64 | ||
3110ff80 | 65 | dprintk("%s: call getattr\n", __func__); |
0e574af1 | 66 | nfs_fattr_init(fattr); |
37ca8f5c EK |
67 | status = rpc_call_sync(server->client, &msg, 0); |
68 | /* Retry with default authentication if different */ | |
69 | if (status && server->nfs_client->cl_rpcclient != server->client) | |
70 | status = rpc_call_sync(server->nfs_client->cl_rpcclient, &msg, 0); | |
3110ff80 | 71 | dprintk("%s: reply getattr: %d\n", __func__, status); |
1da177e4 LT |
72 | if (status) |
73 | return status; | |
3110ff80 | 74 | dprintk("%s: call statfs\n", __func__); |
dead28da CL |
75 | msg.rpc_proc = &nfs_procedures[NFSPROC_STATFS]; |
76 | msg.rpc_resp = &fsinfo; | |
37ca8f5c EK |
77 | status = rpc_call_sync(server->client, &msg, 0); |
78 | /* Retry with default authentication if different */ | |
79 | if (status && server->nfs_client->cl_rpcclient != server->client) | |
80 | status = rpc_call_sync(server->nfs_client->cl_rpcclient, &msg, 0); | |
3110ff80 | 81 | dprintk("%s: reply statfs: %d\n", __func__, status); |
1da177e4 LT |
82 | if (status) |
83 | return status; | |
84 | info->rtmax = NFS_MAXDATA; | |
85 | info->rtpref = fsinfo.tsize; | |
86 | info->rtmult = fsinfo.bsize; | |
87 | info->wtmax = NFS_MAXDATA; | |
88 | info->wtpref = fsinfo.tsize; | |
89 | info->wtmult = fsinfo.bsize; | |
90 | info->dtpref = fsinfo.tsize; | |
91 | info->maxfilesize = 0x7FFFFFFF; | |
92 | info->lease_time = 0; | |
93 | return 0; | |
94 | } | |
95 | ||
96 | /* | |
97 | * One function for each procedure in the NFS protocol. | |
98 | */ | |
99 | static int | |
100 | nfs_proc_getattr(struct nfs_server *server, struct nfs_fh *fhandle, | |
1775fd3e | 101 | struct nfs_fattr *fattr, struct nfs4_label *label) |
1da177e4 | 102 | { |
dead28da CL |
103 | struct rpc_message msg = { |
104 | .rpc_proc = &nfs_procedures[NFSPROC_GETATTR], | |
105 | .rpc_argp = fhandle, | |
106 | .rpc_resp = fattr, | |
107 | }; | |
1da177e4 LT |
108 | int status; |
109 | ||
110 | dprintk("NFS call getattr\n"); | |
0e574af1 | 111 | nfs_fattr_init(fattr); |
dead28da | 112 | status = rpc_call_sync(server->client, &msg, 0); |
1da177e4 LT |
113 | dprintk("NFS reply getattr: %d\n", status); |
114 | return status; | |
115 | } | |
116 | ||
117 | static int | |
118 | nfs_proc_setattr(struct dentry *dentry, struct nfs_fattr *fattr, | |
119 | struct iattr *sattr) | |
120 | { | |
121 | struct inode *inode = dentry->d_inode; | |
122 | struct nfs_sattrargs arg = { | |
123 | .fh = NFS_FH(inode), | |
124 | .sattr = sattr | |
125 | }; | |
dead28da CL |
126 | struct rpc_message msg = { |
127 | .rpc_proc = &nfs_procedures[NFSPROC_SETATTR], | |
128 | .rpc_argp = &arg, | |
129 | .rpc_resp = fattr, | |
130 | }; | |
1da177e4 LT |
131 | int status; |
132 | ||
cf3fff54 TM |
133 | /* Mask out the non-modebit related stuff from attr->ia_mode */ |
134 | sattr->ia_mode &= S_IALLUGO; | |
135 | ||
1da177e4 | 136 | dprintk("NFS call setattr\n"); |
659bfcd6 TM |
137 | if (sattr->ia_valid & ATTR_FILE) |
138 | msg.rpc_cred = nfs_file_cred(sattr->ia_file); | |
0e574af1 | 139 | nfs_fattr_init(fattr); |
dead28da | 140 | status = rpc_call_sync(NFS_CLIENT(inode), &msg, 0); |
65e4308d TM |
141 | if (status == 0) |
142 | nfs_setattr_update_inode(inode, sattr); | |
1da177e4 LT |
143 | dprintk("NFS reply setattr: %d\n", status); |
144 | return status; | |
145 | } | |
146 | ||
147 | static int | |
80a16b21 | 148 | nfs_proc_lookup(struct inode *dir, struct qstr *name, |
1775fd3e DQ |
149 | struct nfs_fh *fhandle, struct nfs_fattr *fattr, |
150 | struct nfs4_label *label) | |
1da177e4 LT |
151 | { |
152 | struct nfs_diropargs arg = { | |
153 | .fh = NFS_FH(dir), | |
154 | .name = name->name, | |
155 | .len = name->len | |
156 | }; | |
157 | struct nfs_diropok res = { | |
158 | .fh = fhandle, | |
159 | .fattr = fattr | |
160 | }; | |
dead28da CL |
161 | struct rpc_message msg = { |
162 | .rpc_proc = &nfs_procedures[NFSPROC_LOOKUP], | |
163 | .rpc_argp = &arg, | |
164 | .rpc_resp = &res, | |
165 | }; | |
1da177e4 LT |
166 | int status; |
167 | ||
168 | dprintk("NFS call lookup %s\n", name->name); | |
0e574af1 | 169 | nfs_fattr_init(fattr); |
dead28da | 170 | status = rpc_call_sync(NFS_CLIENT(dir), &msg, 0); |
1da177e4 LT |
171 | dprintk("NFS reply lookup: %d\n", status); |
172 | return status; | |
173 | } | |
174 | ||
175 | static int nfs_proc_readlink(struct inode *inode, struct page *page, | |
176 | unsigned int pgbase, unsigned int pglen) | |
177 | { | |
178 | struct nfs_readlinkargs args = { | |
179 | .fh = NFS_FH(inode), | |
180 | .pgbase = pgbase, | |
181 | .pglen = pglen, | |
182 | .pages = &page | |
183 | }; | |
dead28da CL |
184 | struct rpc_message msg = { |
185 | .rpc_proc = &nfs_procedures[NFSPROC_READLINK], | |
186 | .rpc_argp = &args, | |
187 | }; | |
1da177e4 LT |
188 | int status; |
189 | ||
190 | dprintk("NFS call readlink\n"); | |
dead28da | 191 | status = rpc_call_sync(NFS_CLIENT(inode), &msg, 0); |
1da177e4 LT |
192 | dprintk("NFS reply readlink: %d\n", status); |
193 | return status; | |
194 | } | |
195 | ||
eb872f0c TM |
196 | struct nfs_createdata { |
197 | struct nfs_createargs arg; | |
198 | struct nfs_diropok res; | |
199 | struct nfs_fh fhandle; | |
200 | struct nfs_fattr fattr; | |
201 | }; | |
202 | ||
203 | static struct nfs_createdata *nfs_alloc_createdata(struct inode *dir, | |
204 | struct dentry *dentry, struct iattr *sattr) | |
205 | { | |
206 | struct nfs_createdata *data; | |
207 | ||
208 | data = kmalloc(sizeof(*data), GFP_KERNEL); | |
209 | ||
210 | if (data != NULL) { | |
211 | data->arg.fh = NFS_FH(dir); | |
212 | data->arg.name = dentry->d_name.name; | |
213 | data->arg.len = dentry->d_name.len; | |
214 | data->arg.sattr = sattr; | |
215 | nfs_fattr_init(&data->fattr); | |
216 | data->fhandle.size = 0; | |
217 | data->res.fh = &data->fhandle; | |
218 | data->res.fattr = &data->fattr; | |
219 | } | |
220 | return data; | |
221 | }; | |
222 | ||
223 | static void nfs_free_createdata(const struct nfs_createdata *data) | |
224 | { | |
225 | kfree(data); | |
226 | } | |
227 | ||
1da177e4 LT |
228 | static int |
229 | nfs_proc_create(struct inode *dir, struct dentry *dentry, struct iattr *sattr, | |
8867fe58 | 230 | int flags) |
1da177e4 | 231 | { |
eb872f0c | 232 | struct nfs_createdata *data; |
dead28da CL |
233 | struct rpc_message msg = { |
234 | .rpc_proc = &nfs_procedures[NFSPROC_CREATE], | |
dead28da | 235 | }; |
eb872f0c | 236 | int status = -ENOMEM; |
1da177e4 | 237 | |
6de1472f | 238 | dprintk("NFS call create %pd\n", dentry); |
eb872f0c TM |
239 | data = nfs_alloc_createdata(dir, dentry, sattr); |
240 | if (data == NULL) | |
241 | goto out; | |
242 | msg.rpc_argp = &data->arg; | |
243 | msg.rpc_resp = &data->res; | |
dead28da | 244 | status = rpc_call_sync(NFS_CLIENT(dir), &msg, 0); |
bad2a524 | 245 | nfs_mark_for_revalidate(dir); |
1da177e4 | 246 | if (status == 0) |
1775fd3e | 247 | status = nfs_instantiate(dentry, data->res.fh, data->res.fattr, NULL); |
eb872f0c TM |
248 | nfs_free_createdata(data); |
249 | out: | |
1da177e4 LT |
250 | dprintk("NFS reply create: %d\n", status); |
251 | return status; | |
252 | } | |
253 | ||
254 | /* | |
255 | * In NFSv2, mknod is grafted onto the create call. | |
256 | */ | |
257 | static int | |
258 | nfs_proc_mknod(struct inode *dir, struct dentry *dentry, struct iattr *sattr, | |
259 | dev_t rdev) | |
260 | { | |
eb872f0c | 261 | struct nfs_createdata *data; |
dead28da CL |
262 | struct rpc_message msg = { |
263 | .rpc_proc = &nfs_procedures[NFSPROC_CREATE], | |
dead28da | 264 | }; |
eb872f0c TM |
265 | umode_t mode; |
266 | int status = -ENOMEM; | |
1da177e4 | 267 | |
6de1472f | 268 | dprintk("NFS call mknod %pd\n", dentry); |
1da177e4 LT |
269 | |
270 | mode = sattr->ia_mode; | |
271 | if (S_ISFIFO(mode)) { | |
272 | sattr->ia_mode = (mode & ~S_IFMT) | S_IFCHR; | |
273 | sattr->ia_valid &= ~ATTR_SIZE; | |
274 | } else if (S_ISCHR(mode) || S_ISBLK(mode)) { | |
275 | sattr->ia_valid |= ATTR_SIZE; | |
276 | sattr->ia_size = new_encode_dev(rdev);/* get out your barf bag */ | |
277 | } | |
278 | ||
eb872f0c TM |
279 | data = nfs_alloc_createdata(dir, dentry, sattr); |
280 | if (data == NULL) | |
281 | goto out; | |
282 | msg.rpc_argp = &data->arg; | |
283 | msg.rpc_resp = &data->res; | |
284 | ||
dead28da | 285 | status = rpc_call_sync(NFS_CLIENT(dir), &msg, 0); |
decf491f | 286 | nfs_mark_for_revalidate(dir); |
1da177e4 LT |
287 | |
288 | if (status == -EINVAL && S_ISFIFO(mode)) { | |
289 | sattr->ia_mode = mode; | |
eb872f0c | 290 | nfs_fattr_init(data->res.fattr); |
dead28da | 291 | status = rpc_call_sync(NFS_CLIENT(dir), &msg, 0); |
1da177e4 LT |
292 | } |
293 | if (status == 0) | |
1775fd3e | 294 | status = nfs_instantiate(dentry, data->res.fh, data->res.fattr, NULL); |
eb872f0c TM |
295 | nfs_free_createdata(data); |
296 | out: | |
1da177e4 LT |
297 | dprintk("NFS reply mknod: %d\n", status); |
298 | return status; | |
299 | } | |
300 | ||
301 | static int | |
302 | nfs_proc_remove(struct inode *dir, struct qstr *name) | |
303 | { | |
4fdc17b2 TM |
304 | struct nfs_removeargs arg = { |
305 | .fh = NFS_FH(dir), | |
26fe5750 | 306 | .name = *name, |
1da177e4 | 307 | }; |
4fdc17b2 TM |
308 | struct rpc_message msg = { |
309 | .rpc_proc = &nfs_procedures[NFSPROC_REMOVE], | |
310 | .rpc_argp = &arg, | |
1da177e4 LT |
311 | }; |
312 | int status; | |
313 | ||
314 | dprintk("NFS call remove %s\n", name->name); | |
315 | status = rpc_call_sync(NFS_CLIENT(dir), &msg, 0); | |
decf491f | 316 | nfs_mark_for_revalidate(dir); |
1da177e4 LT |
317 | |
318 | dprintk("NFS reply remove: %d\n", status); | |
319 | return status; | |
320 | } | |
321 | ||
e4eff1a6 TM |
322 | static void |
323 | nfs_proc_unlink_setup(struct rpc_message *msg, struct inode *dir) | |
1da177e4 | 324 | { |
1da177e4 | 325 | msg->rpc_proc = &nfs_procedures[NFSPROC_REMOVE]; |
1da177e4 LT |
326 | } |
327 | ||
34e137cc BS |
328 | static void nfs_proc_unlink_rpc_prepare(struct rpc_task *task, struct nfs_unlinkdata *data) |
329 | { | |
330 | rpc_call_start(task); | |
331 | } | |
332 | ||
e4eff1a6 | 333 | static int nfs_proc_unlink_done(struct rpc_task *task, struct inode *dir) |
1da177e4 | 334 | { |
e4eff1a6 TM |
335 | nfs_mark_for_revalidate(dir); |
336 | return 1; | |
1da177e4 LT |
337 | } |
338 | ||
d3d4152a JL |
339 | static void |
340 | nfs_proc_rename_setup(struct rpc_message *msg, struct inode *dir) | |
341 | { | |
342 | msg->rpc_proc = &nfs_procedures[NFSPROC_RENAME]; | |
343 | } | |
344 | ||
c6bfa1a1 BS |
345 | static void nfs_proc_rename_rpc_prepare(struct rpc_task *task, struct nfs_renamedata *data) |
346 | { | |
347 | rpc_call_start(task); | |
348 | } | |
349 | ||
d3d4152a JL |
350 | static int |
351 | nfs_proc_rename_done(struct rpc_task *task, struct inode *old_dir, | |
352 | struct inode *new_dir) | |
353 | { | |
d3d4152a JL |
354 | nfs_mark_for_revalidate(old_dir); |
355 | nfs_mark_for_revalidate(new_dir); | |
356 | return 1; | |
357 | } | |
358 | ||
1da177e4 LT |
359 | static int |
360 | nfs_proc_rename(struct inode *old_dir, struct qstr *old_name, | |
361 | struct inode *new_dir, struct qstr *new_name) | |
362 | { | |
363 | struct nfs_renameargs arg = { | |
920769f0 JL |
364 | .old_dir = NFS_FH(old_dir), |
365 | .old_name = old_name, | |
366 | .new_dir = NFS_FH(new_dir), | |
367 | .new_name = new_name, | |
1da177e4 | 368 | }; |
dead28da CL |
369 | struct rpc_message msg = { |
370 | .rpc_proc = &nfs_procedures[NFSPROC_RENAME], | |
371 | .rpc_argp = &arg, | |
372 | }; | |
1da177e4 LT |
373 | int status; |
374 | ||
375 | dprintk("NFS call rename %s -> %s\n", old_name->name, new_name->name); | |
dead28da | 376 | status = rpc_call_sync(NFS_CLIENT(old_dir), &msg, 0); |
decf491f TM |
377 | nfs_mark_for_revalidate(old_dir); |
378 | nfs_mark_for_revalidate(new_dir); | |
1da177e4 LT |
379 | dprintk("NFS reply rename: %d\n", status); |
380 | return status; | |
381 | } | |
382 | ||
383 | static int | |
384 | nfs_proc_link(struct inode *inode, struct inode *dir, struct qstr *name) | |
385 | { | |
386 | struct nfs_linkargs arg = { | |
387 | .fromfh = NFS_FH(inode), | |
388 | .tofh = NFS_FH(dir), | |
389 | .toname = name->name, | |
390 | .tolen = name->len | |
391 | }; | |
dead28da CL |
392 | struct rpc_message msg = { |
393 | .rpc_proc = &nfs_procedures[NFSPROC_LINK], | |
394 | .rpc_argp = &arg, | |
395 | }; | |
1da177e4 LT |
396 | int status; |
397 | ||
398 | dprintk("NFS call link %s\n", name->name); | |
dead28da | 399 | status = rpc_call_sync(NFS_CLIENT(inode), &msg, 0); |
5ba7cc48 | 400 | nfs_mark_for_revalidate(inode); |
decf491f | 401 | nfs_mark_for_revalidate(dir); |
1da177e4 LT |
402 | dprintk("NFS reply link: %d\n", status); |
403 | return status; | |
404 | } | |
405 | ||
406 | static int | |
94a6d753 CL |
407 | nfs_proc_symlink(struct inode *dir, struct dentry *dentry, struct page *page, |
408 | unsigned int len, struct iattr *sattr) | |
1da177e4 | 409 | { |
23a30612 TM |
410 | struct nfs_fh *fh; |
411 | struct nfs_fattr *fattr; | |
1da177e4 LT |
412 | struct nfs_symlinkargs arg = { |
413 | .fromfh = NFS_FH(dir), | |
4f390c15 CL |
414 | .fromname = dentry->d_name.name, |
415 | .fromlen = dentry->d_name.len, | |
94a6d753 CL |
416 | .pages = &page, |
417 | .pathlen = len, | |
1da177e4 LT |
418 | .sattr = sattr |
419 | }; | |
dead28da CL |
420 | struct rpc_message msg = { |
421 | .rpc_proc = &nfs_procedures[NFSPROC_SYMLINK], | |
422 | .rpc_argp = &arg, | |
423 | }; | |
23a30612 TM |
424 | int status = -ENAMETOOLONG; |
425 | ||
6de1472f | 426 | dprintk("NFS call symlink %pd\n", dentry); |
1da177e4 | 427 | |
94a6d753 | 428 | if (len > NFS2_MAXPATHLEN) |
23a30612 | 429 | goto out; |
4f390c15 | 430 | |
23a30612 TM |
431 | fh = nfs_alloc_fhandle(); |
432 | fattr = nfs_alloc_fattr(); | |
433 | status = -ENOMEM; | |
434 | if (fh == NULL || fattr == NULL) | |
878215fe | 435 | goto out_free; |
94a6d753 | 436 | |
dead28da | 437 | status = rpc_call_sync(NFS_CLIENT(dir), &msg, 0); |
decf491f | 438 | nfs_mark_for_revalidate(dir); |
4f390c15 CL |
439 | |
440 | /* | |
441 | * V2 SYMLINK requests don't return any attributes. Setting the | |
442 | * filehandle size to zero indicates to nfs_instantiate that it | |
443 | * should fill in the data with a LOOKUP call on the wire. | |
444 | */ | |
23a30612 | 445 | if (status == 0) |
1775fd3e | 446 | status = nfs_instantiate(dentry, fh, fattr, NULL); |
4f390c15 | 447 | |
878215fe | 448 | out_free: |
23a30612 TM |
449 | nfs_free_fattr(fattr); |
450 | nfs_free_fhandle(fh); | |
451 | out: | |
1da177e4 LT |
452 | dprintk("NFS reply symlink: %d\n", status); |
453 | return status; | |
454 | } | |
455 | ||
456 | static int | |
457 | nfs_proc_mkdir(struct inode *dir, struct dentry *dentry, struct iattr *sattr) | |
458 | { | |
eb872f0c | 459 | struct nfs_createdata *data; |
dead28da CL |
460 | struct rpc_message msg = { |
461 | .rpc_proc = &nfs_procedures[NFSPROC_MKDIR], | |
dead28da | 462 | }; |
eb872f0c | 463 | int status = -ENOMEM; |
1da177e4 | 464 | |
6de1472f | 465 | dprintk("NFS call mkdir %pd\n", dentry); |
eb872f0c TM |
466 | data = nfs_alloc_createdata(dir, dentry, sattr); |
467 | if (data == NULL) | |
468 | goto out; | |
469 | msg.rpc_argp = &data->arg; | |
470 | msg.rpc_resp = &data->res; | |
471 | ||
dead28da | 472 | status = rpc_call_sync(NFS_CLIENT(dir), &msg, 0); |
decf491f | 473 | nfs_mark_for_revalidate(dir); |
1da177e4 | 474 | if (status == 0) |
1775fd3e | 475 | status = nfs_instantiate(dentry, data->res.fh, data->res.fattr, NULL); |
eb872f0c TM |
476 | nfs_free_createdata(data); |
477 | out: | |
1da177e4 LT |
478 | dprintk("NFS reply mkdir: %d\n", status); |
479 | return status; | |
480 | } | |
481 | ||
482 | static int | |
483 | nfs_proc_rmdir(struct inode *dir, struct qstr *name) | |
484 | { | |
485 | struct nfs_diropargs arg = { | |
486 | .fh = NFS_FH(dir), | |
487 | .name = name->name, | |
488 | .len = name->len | |
489 | }; | |
dead28da CL |
490 | struct rpc_message msg = { |
491 | .rpc_proc = &nfs_procedures[NFSPROC_RMDIR], | |
492 | .rpc_argp = &arg, | |
493 | }; | |
1da177e4 LT |
494 | int status; |
495 | ||
496 | dprintk("NFS call rmdir %s\n", name->name); | |
dead28da | 497 | status = rpc_call_sync(NFS_CLIENT(dir), &msg, 0); |
decf491f | 498 | nfs_mark_for_revalidate(dir); |
1da177e4 LT |
499 | dprintk("NFS reply rmdir: %d\n", status); |
500 | return status; | |
501 | } | |
502 | ||
503 | /* | |
504 | * The READDIR implementation is somewhat hackish - we pass a temporary | |
505 | * buffer to the encode function, which installs it in the receive | |
506 | * the receive iovec. The decode function just parses the reply to make | |
507 | * sure it is syntactically correct; the entries itself are decoded | |
508 | * from nfs_readdir by calling the decode_entry function directly. | |
509 | */ | |
510 | static int | |
511 | nfs_proc_readdir(struct dentry *dentry, struct rpc_cred *cred, | |
56e4ebf8 | 512 | u64 cookie, struct page **pages, unsigned int count, int plus) |
1da177e4 LT |
513 | { |
514 | struct inode *dir = dentry->d_inode; | |
515 | struct nfs_readdirargs arg = { | |
516 | .fh = NFS_FH(dir), | |
517 | .cookie = cookie, | |
518 | .count = count, | |
56e4ebf8 | 519 | .pages = pages, |
1da177e4 LT |
520 | }; |
521 | struct rpc_message msg = { | |
522 | .rpc_proc = &nfs_procedures[NFSPROC_READDIR], | |
523 | .rpc_argp = &arg, | |
dead28da | 524 | .rpc_cred = cred, |
1da177e4 LT |
525 | }; |
526 | int status; | |
527 | ||
1da177e4 LT |
528 | dprintk("NFS call readdir %d\n", (unsigned int)cookie); |
529 | status = rpc_call_sync(NFS_CLIENT(dir), &msg, 0); | |
530 | ||
c4812998 TM |
531 | nfs_invalidate_atime(dir); |
532 | ||
1da177e4 | 533 | dprintk("NFS reply readdir: %d\n", status); |
1da177e4 LT |
534 | return status; |
535 | } | |
536 | ||
537 | static int | |
538 | nfs_proc_statfs(struct nfs_server *server, struct nfs_fh *fhandle, | |
539 | struct nfs_fsstat *stat) | |
540 | { | |
541 | struct nfs2_fsstat fsinfo; | |
dead28da CL |
542 | struct rpc_message msg = { |
543 | .rpc_proc = &nfs_procedures[NFSPROC_STATFS], | |
544 | .rpc_argp = fhandle, | |
545 | .rpc_resp = &fsinfo, | |
546 | }; | |
1da177e4 LT |
547 | int status; |
548 | ||
549 | dprintk("NFS call statfs\n"); | |
0e574af1 | 550 | nfs_fattr_init(stat->fattr); |
dead28da | 551 | status = rpc_call_sync(server->client, &msg, 0); |
1da177e4 LT |
552 | dprintk("NFS reply statfs: %d\n", status); |
553 | if (status) | |
554 | goto out; | |
555 | stat->tbytes = (u64)fsinfo.blocks * fsinfo.bsize; | |
556 | stat->fbytes = (u64)fsinfo.bfree * fsinfo.bsize; | |
557 | stat->abytes = (u64)fsinfo.bavail * fsinfo.bsize; | |
558 | stat->tfiles = 0; | |
559 | stat->ffiles = 0; | |
560 | stat->afiles = 0; | |
561 | out: | |
562 | return status; | |
563 | } | |
564 | ||
565 | static int | |
566 | nfs_proc_fsinfo(struct nfs_server *server, struct nfs_fh *fhandle, | |
567 | struct nfs_fsinfo *info) | |
568 | { | |
569 | struct nfs2_fsstat fsinfo; | |
dead28da CL |
570 | struct rpc_message msg = { |
571 | .rpc_proc = &nfs_procedures[NFSPROC_STATFS], | |
572 | .rpc_argp = fhandle, | |
573 | .rpc_resp = &fsinfo, | |
574 | }; | |
1da177e4 LT |
575 | int status; |
576 | ||
577 | dprintk("NFS call fsinfo\n"); | |
0e574af1 | 578 | nfs_fattr_init(info->fattr); |
dead28da | 579 | status = rpc_call_sync(server->client, &msg, 0); |
1da177e4 LT |
580 | dprintk("NFS reply fsinfo: %d\n", status); |
581 | if (status) | |
582 | goto out; | |
583 | info->rtmax = NFS_MAXDATA; | |
584 | info->rtpref = fsinfo.tsize; | |
585 | info->rtmult = fsinfo.bsize; | |
586 | info->wtmax = NFS_MAXDATA; | |
587 | info->wtpref = fsinfo.tsize; | |
588 | info->wtmult = fsinfo.bsize; | |
589 | info->dtpref = fsinfo.tsize; | |
590 | info->maxfilesize = 0x7FFFFFFF; | |
591 | info->lease_time = 0; | |
592 | out: | |
593 | return status; | |
594 | } | |
595 | ||
596 | static int | |
597 | nfs_proc_pathconf(struct nfs_server *server, struct nfs_fh *fhandle, | |
598 | struct nfs_pathconf *info) | |
599 | { | |
600 | info->max_link = 0; | |
601 | info->max_namelen = NFS2_MAXNAMLEN; | |
602 | return 0; | |
603 | } | |
604 | ||
ec06c096 | 605 | static int nfs_read_done(struct rpc_task *task, struct nfs_read_data *data) |
1da177e4 | 606 | { |
cd841605 FI |
607 | struct inode *inode = data->header->inode; |
608 | ||
cd841605 | 609 | nfs_invalidate_atime(inode); |
1da177e4 | 610 | if (task->tk_status >= 0) { |
cd841605 | 611 | nfs_refresh_inode(inode, data->res.fattr); |
1da177e4 LT |
612 | /* Emulate the eof flag, which isn't normally needed in NFSv2 |
613 | * as it is guaranteed to always return the file attributes | |
614 | */ | |
64f9a836 | 615 | if (data->args.offset + data->res.count >= data->res.fattr->size) |
1da177e4 LT |
616 | data->res.eof = 1; |
617 | } | |
ec06c096 | 618 | return 0; |
1da177e4 LT |
619 | } |
620 | ||
bdc7f021 | 621 | static void nfs_proc_read_setup(struct nfs_read_data *data, struct rpc_message *msg) |
1da177e4 | 622 | { |
bdc7f021 | 623 | msg->rpc_proc = &nfs_procedures[NFSPROC_READ]; |
1da177e4 LT |
624 | } |
625 | ||
ef1820f9 | 626 | static int nfs_proc_read_rpc_prepare(struct rpc_task *task, struct nfs_read_data *data) |
ea7c3303 BS |
627 | { |
628 | rpc_call_start(task); | |
ef1820f9 | 629 | return 0; |
ea7c3303 BS |
630 | } |
631 | ||
788e7a89 | 632 | static int nfs_write_done(struct rpc_task *task, struct nfs_write_data *data) |
1da177e4 | 633 | { |
cd841605 FI |
634 | struct inode *inode = data->header->inode; |
635 | ||
1da177e4 | 636 | if (task->tk_status >= 0) |
cd841605 | 637 | nfs_post_op_update_inode_force_wcc(inode, data->res.fattr); |
788e7a89 | 638 | return 0; |
1da177e4 LT |
639 | } |
640 | ||
bdc7f021 | 641 | static void nfs_proc_write_setup(struct nfs_write_data *data, struct rpc_message *msg) |
1da177e4 | 642 | { |
1da177e4 LT |
643 | /* Note: NFSv2 ignores @stable and always uses NFS_FILE_SYNC */ |
644 | data->args.stable = NFS_FILE_SYNC; | |
bdc7f021 | 645 | msg->rpc_proc = &nfs_procedures[NFSPROC_WRITE]; |
1da177e4 LT |
646 | } |
647 | ||
ef1820f9 | 648 | static int nfs_proc_write_rpc_prepare(struct rpc_task *task, struct nfs_write_data *data) |
c6cb80d0 BS |
649 | { |
650 | rpc_call_start(task); | |
ef1820f9 | 651 | return 0; |
c6cb80d0 BS |
652 | } |
653 | ||
0b7c0153 FI |
654 | static void nfs_proc_commit_rpc_prepare(struct rpc_task *task, struct nfs_commit_data *data) |
655 | { | |
656 | BUG(); | |
657 | } | |
658 | ||
1da177e4 | 659 | static void |
0b7c0153 | 660 | nfs_proc_commit_setup(struct nfs_commit_data *data, struct rpc_message *msg) |
1da177e4 LT |
661 | { |
662 | BUG(); | |
663 | } | |
664 | ||
665 | static int | |
666 | nfs_proc_lock(struct file *filp, int cmd, struct file_lock *fl) | |
667 | { | |
496ad9aa | 668 | struct inode *inode = file_inode(filp); |
1093a60e CL |
669 | |
670 | return nlmclnt_proc(NFS_SERVER(inode)->nlm_host, cmd, fl); | |
1da177e4 LT |
671 | } |
672 | ||
2116271a TM |
673 | /* Helper functions for NFS lock bounds checking */ |
674 | #define NFS_LOCK32_OFFSET_MAX ((__s32)0x7fffffffUL) | |
675 | static int nfs_lock_check_bounds(const struct file_lock *fl) | |
676 | { | |
677 | __s32 start, end; | |
678 | ||
679 | start = (__s32)fl->fl_start; | |
680 | if ((loff_t)start != fl->fl_start) | |
681 | goto out_einval; | |
682 | ||
683 | if (fl->fl_end != OFFSET_MAX) { | |
684 | end = (__s32)fl->fl_end; | |
685 | if ((loff_t)end != fl->fl_end) | |
686 | goto out_einval; | |
687 | } else | |
688 | end = NFS_LOCK32_OFFSET_MAX; | |
689 | ||
690 | if (start < 0 || start > end) | |
691 | goto out_einval; | |
692 | return 0; | |
693 | out_einval: | |
694 | return -EINVAL; | |
695 | } | |
1da177e4 | 696 | |
011e2a7f BS |
697 | static int nfs_have_delegation(struct inode *inode, fmode_t flags) |
698 | { | |
699 | return 0; | |
700 | } | |
701 | ||
57ec14c5 BS |
702 | static int nfs_return_delegation(struct inode *inode) |
703 | { | |
704 | nfs_wb_all(inode); | |
705 | return 0; | |
706 | } | |
707 | ||
597d9289 BS |
708 | static const struct inode_operations nfs_dir_inode_operations = { |
709 | .create = nfs_create, | |
710 | .lookup = nfs_lookup, | |
711 | .link = nfs_link, | |
712 | .unlink = nfs_unlink, | |
713 | .symlink = nfs_symlink, | |
714 | .mkdir = nfs_mkdir, | |
715 | .rmdir = nfs_rmdir, | |
716 | .mknod = nfs_mknod, | |
717 | .rename = nfs_rename, | |
718 | .permission = nfs_permission, | |
719 | .getattr = nfs_getattr, | |
720 | .setattr = nfs_setattr, | |
721 | }; | |
722 | ||
723 | static const struct inode_operations nfs_file_inode_operations = { | |
724 | .permission = nfs_permission, | |
725 | .getattr = nfs_getattr, | |
726 | .setattr = nfs_setattr, | |
727 | }; | |
728 | ||
509de811 | 729 | const struct nfs_rpc_ops nfs_v2_clientops = { |
1da177e4 LT |
730 | .version = 2, /* protocol version */ |
731 | .dentry_ops = &nfs_dentry_operations, | |
732 | .dir_inode_ops = &nfs_dir_inode_operations, | |
92cfc62c | 733 | .file_inode_ops = &nfs_file_inode_operations, |
1788ea6e | 734 | .file_ops = &nfs_file_operations, |
1da177e4 | 735 | .getroot = nfs_proc_get_root, |
281cad46 | 736 | .submount = nfs_submount, |
ff9099f2 | 737 | .try_mount = nfs_try_mount, |
1da177e4 LT |
738 | .getattr = nfs_proc_getattr, |
739 | .setattr = nfs_proc_setattr, | |
740 | .lookup = nfs_proc_lookup, | |
741 | .access = NULL, /* access */ | |
742 | .readlink = nfs_proc_readlink, | |
1da177e4 LT |
743 | .create = nfs_proc_create, |
744 | .remove = nfs_proc_remove, | |
745 | .unlink_setup = nfs_proc_unlink_setup, | |
34e137cc | 746 | .unlink_rpc_prepare = nfs_proc_unlink_rpc_prepare, |
1da177e4 LT |
747 | .unlink_done = nfs_proc_unlink_done, |
748 | .rename = nfs_proc_rename, | |
d3d4152a | 749 | .rename_setup = nfs_proc_rename_setup, |
c6bfa1a1 | 750 | .rename_rpc_prepare = nfs_proc_rename_rpc_prepare, |
d3d4152a | 751 | .rename_done = nfs_proc_rename_done, |
1da177e4 LT |
752 | .link = nfs_proc_link, |
753 | .symlink = nfs_proc_symlink, | |
754 | .mkdir = nfs_proc_mkdir, | |
755 | .rmdir = nfs_proc_rmdir, | |
756 | .readdir = nfs_proc_readdir, | |
757 | .mknod = nfs_proc_mknod, | |
758 | .statfs = nfs_proc_statfs, | |
759 | .fsinfo = nfs_proc_fsinfo, | |
760 | .pathconf = nfs_proc_pathconf, | |
f796f8b3 | 761 | .decode_dirent = nfs2_decode_dirent, |
1da177e4 | 762 | .read_setup = nfs_proc_read_setup, |
1abb5088 | 763 | .read_pageio_init = nfs_pageio_init_read, |
ea7c3303 | 764 | .read_rpc_prepare = nfs_proc_read_rpc_prepare, |
ec06c096 | 765 | .read_done = nfs_read_done, |
1da177e4 | 766 | .write_setup = nfs_proc_write_setup, |
57208fa7 | 767 | .write_pageio_init = nfs_pageio_init_write, |
c6cb80d0 | 768 | .write_rpc_prepare = nfs_proc_write_rpc_prepare, |
788e7a89 | 769 | .write_done = nfs_write_done, |
1da177e4 | 770 | .commit_setup = nfs_proc_commit_setup, |
0b7c0153 | 771 | .commit_rpc_prepare = nfs_proc_commit_rpc_prepare, |
1da177e4 | 772 | .lock = nfs_proc_lock, |
2116271a | 773 | .lock_check_bounds = nfs_lock_check_bounds, |
7fe5c398 | 774 | .close_context = nfs_close_context, |
011e2a7f | 775 | .have_delegation = nfs_have_delegation, |
57ec14c5 | 776 | .return_delegation = nfs_return_delegation, |
6663ee7f | 777 | .alloc_client = nfs_alloc_client, |
45a52a02 | 778 | .init_client = nfs_init_client, |
cdb7eced | 779 | .free_client = nfs_free_client, |
1179acc6 BS |
780 | .create_server = nfs_create_server, |
781 | .clone_server = nfs_clone_server, | |
1da177e4 | 782 | }; |