]> git.ipfire.org Git - thirdparty/linux.git/blob - fs/afs/fsclient.c
projects / thirdparty / linux.git / blob
? search:
summary | shortlog | log | commit | commitdiff | tree
blame | history | raw | HEAD
MAINTAINERS: Fix Hyperv vIOMMU driver file name
[thirdparty/linux.git] / fs / afs / fsclient.c
1 // SPDX-License-Identifier: GPL-2.0-or-later
2 /* AFS File Server client stubs
3 *
4 * Copyright (C) 2002, 2007 Red Hat, Inc. All Rights Reserved.
5 * Written by David Howells (dhowells@redhat.com)
6 */
7
8 #include <linux/init.h>
9 #include <linux/slab.h>
10 #include <linux/sched.h>
11 #include <linux/circ_buf.h>
12 #include <linux/iversion.h>
13 #include "internal.h"
14 #include "afs_fs.h"
15 #include "xdr_fs.h"
16 #include "protocol_yfs.h"
17
18 static const struct afs_fid afs_zero_fid;
19
20 static inline void afs_use_fs_server(struct afs_call *call, struct afs_cb_interest *cbi)
21 {
22 call->cbi = afs_get_cb_interest(cbi);
23 }
24
25 /*
26 * decode an AFSFid block
27 */
28 static void xdr_decode_AFSFid(const __be32 **_bp, struct afs_fid *fid)
29 {
30 const __be32 *bp = *_bp;
31
32 fid->vid = ntohl(*bp++);
33 fid->vnode = ntohl(*bp++);
34 fid->unique = ntohl(*bp++);
35 *_bp = bp;
36 }
37
38 /*
39 * Dump a bad file status record.
40 */
41 static void xdr_dump_bad(const __be32 *bp)
42 {
43 __be32 x[4];
44 int i;
45
46 pr_notice("AFS XDR: Bad status record\n");
47 for (i = 0; i < 5 * 4 * 4; i += 16) {
48 memcpy(x, bp, 16);
49 bp += 4;
50 pr_notice("%03x: %08x %08x %08x %08x\n",
51 i, ntohl(x[0]), ntohl(x[1]), ntohl(x[2]), ntohl(x[3]));
52 }
53
54 memcpy(x, bp, 4);
55 pr_notice("0x50: %08x\n", ntohl(x[0]));
56 }
57
58 /*
59 * decode an AFSFetchStatus block
60 */
61 static int xdr_decode_AFSFetchStatus(const __be32 **_bp,
62 struct afs_call *call,
63 struct afs_status_cb *scb)
64 {
65 const struct afs_xdr_AFSFetchStatus *xdr = (const void *)*_bp;
66 struct afs_file_status *status = &scb->status;
67 bool inline_error = (call->operation_ID == afs_FS_InlineBulkStatus);
68 u64 data_version, size;
69 u32 type, abort_code;
70
71 abort_code = ntohl(xdr->abort_code);
72
73 if (xdr->if_version != htonl(AFS_FSTATUS_VERSION)) {
74 if (xdr->if_version == htonl(0) &&
75 abort_code != 0 &&
76 inline_error) {
77 /* The OpenAFS fileserver has a bug in FS.InlineBulkStatus
78 * whereby it doesn't set the interface version in the error
79 * case.
80 */
81 status->abort_code = abort_code;
82 scb->have_error = true;
83 return 0;
84 }
85
86 pr_warn("Unknown AFSFetchStatus version %u\n", ntohl(xdr->if_version));
87 goto bad;
88 }
89
90 if (abort_code != 0 && inline_error) {
91 status->abort_code = abort_code;
92 return 0;
93 }
94
95 type = ntohl(xdr->type);
96 switch (type) {
97 case AFS_FTYPE_FILE:
98 case AFS_FTYPE_DIR:
99 case AFS_FTYPE_SYMLINK:
100 status->type = type;
101 break;
102 default:
103 goto bad;
104 }
105
106 status->nlink = ntohl(xdr->nlink);
107 status->author = ntohl(xdr->author);
108 status->owner = ntohl(xdr->owner);
109 status->caller_access = ntohl(xdr->caller_access); /* Ticket dependent */
110 status->anon_access = ntohl(xdr->anon_access);
111 status->mode = ntohl(xdr->mode) & S_IALLUGO;
112 status->group = ntohl(xdr->group);
113 status->lock_count = ntohl(xdr->lock_count);
114
115 status->mtime_client.tv_sec = ntohl(xdr->mtime_client);
116 status->mtime_client.tv_nsec = 0;
117 status->mtime_server.tv_sec = ntohl(xdr->mtime_server);
118 status->mtime_server.tv_nsec = 0;
119
120 size = (u64)ntohl(xdr->size_lo);
121 size |= (u64)ntohl(xdr->size_hi) << 32;
122 status->size = size;
123
124 data_version = (u64)ntohl(xdr->data_version_lo);
125 data_version |= (u64)ntohl(xdr->data_version_hi) << 32;
126 status->data_version = data_version;
127 scb->have_status = true;
128
129 *_bp = (const void *)*_bp + sizeof(*xdr);
130 return 0;
131
132 bad:
133 xdr_dump_bad(*_bp);
134 return afs_protocol_error(call, -EBADMSG, afs_eproto_bad_status);
135 }
136
137 static time64_t xdr_decode_expiry(struct afs_call *call, u32 expiry)
138 {
139 return ktime_divns(call->reply_time, NSEC_PER_SEC) + expiry;
140 }
141
142 static void xdr_decode_AFSCallBack(const __be32 **_bp,
143 struct afs_call *call,
144 struct afs_status_cb *scb)
145 {
146 struct afs_callback *cb = &scb->callback;
147 const __be32 *bp = *_bp;
148
149 bp++; /* version */
150 cb->expires_at = xdr_decode_expiry(call, ntohl(*bp++));
151 bp++; /* type */
152 scb->have_cb = true;
153 *_bp = bp;
154 }
155
156 /*
157 * decode an AFSVolSync block
158 */
159 static void xdr_decode_AFSVolSync(const __be32 **_bp,
160 struct afs_volsync *volsync)
161 {
162 const __be32 *bp = *_bp;
163 u32 creation;
164
165 creation = ntohl(*bp++);
166 bp++; /* spare2 */
167 bp++; /* spare3 */
168 bp++; /* spare4 */
169 bp++; /* spare5 */
170 bp++; /* spare6 */
171 *_bp = bp;
172
173 if (volsync)
174 volsync->creation = creation;
175 }
176
177 /*
178 * encode the requested attributes into an AFSStoreStatus block
179 */
180 static void xdr_encode_AFS_StoreStatus(__be32 **_bp, struct iattr *attr)
181 {
182 __be32 *bp = *_bp;
183 u32 mask = 0, mtime = 0, owner = 0, group = 0, mode = 0;
184
185 mask = 0;
186 if (attr->ia_valid & ATTR_MTIME) {
187 mask |= AFS_SET_MTIME;
188 mtime = attr->ia_mtime.tv_sec;
189 }
190
191 if (attr->ia_valid & ATTR_UID) {
192 mask |= AFS_SET_OWNER;
193 owner = from_kuid(&init_user_ns, attr->ia_uid);
194 }
195
196 if (attr->ia_valid & ATTR_GID) {
197 mask |= AFS_SET_GROUP;
198 group = from_kgid(&init_user_ns, attr->ia_gid);
199 }
200
201 if (attr->ia_valid & ATTR_MODE) {
202 mask |= AFS_SET_MODE;
203 mode = attr->ia_mode & S_IALLUGO;
204 }
205
206 *bp++ = htonl(mask);
207 *bp++ = htonl(mtime);
208 *bp++ = htonl(owner);
209 *bp++ = htonl(group);
210 *bp++ = htonl(mode);
211 *bp++ = 0; /* segment size */
212 *_bp = bp;
213 }
214
215 /*
216 * decode an AFSFetchVolumeStatus block
217 */
218 static void xdr_decode_AFSFetchVolumeStatus(const __be32 **_bp,
219 struct afs_volume_status *vs)
220 {
221 const __be32 *bp = *_bp;
222
223 vs->vid = ntohl(*bp++);
224 vs->parent_id = ntohl(*bp++);
225 vs->online = ntohl(*bp++);
226 vs->in_service = ntohl(*bp++);
227 vs->blessed = ntohl(*bp++);
228 vs->needs_salvage = ntohl(*bp++);
229 vs->type = ntohl(*bp++);
230 vs->min_quota = ntohl(*bp++);
231 vs->max_quota = ntohl(*bp++);
232 vs->blocks_in_use = ntohl(*bp++);
233 vs->part_blocks_avail = ntohl(*bp++);
234 vs->part_max_blocks = ntohl(*bp++);
235 vs->vol_copy_date = 0;
236 vs->vol_backup_date = 0;
237 *_bp = bp;
238 }
239
240 /*
241 * deliver reply data to an FS.FetchStatus
242 */
243 static int afs_deliver_fs_fetch_status_vnode(struct afs_call *call)
244 {
245 const __be32 *bp;
246 int ret;
247
248 ret = afs_transfer_reply(call);
249 if (ret < 0)
250 return ret;
251
252 /* unmarshall the reply once we've received all of it */
253 bp = call->buffer;
254 ret = xdr_decode_AFSFetchStatus(&bp, call, call->out_scb);
255 if (ret < 0)
256 return ret;
257 xdr_decode_AFSCallBack(&bp, call, call->out_scb);
258 xdr_decode_AFSVolSync(&bp, call->out_volsync);
259
260 _leave(" = 0 [done]");
261 return 0;
262 }
263
264 /*
265 * FS.FetchStatus operation type
266 */
267 static const struct afs_call_type afs_RXFSFetchStatus_vnode = {
268 .name = "FS.FetchStatus(vnode)",
269 .op = afs_FS_FetchStatus,
270 .deliver = afs_deliver_fs_fetch_status_vnode,
271 .destructor = afs_flat_call_destructor,
272 };
273
274 /*
275 * fetch the status information for a file
276 */
277 int afs_fs_fetch_file_status(struct afs_fs_cursor *fc, struct afs_status_cb *scb,
278 struct afs_volsync *volsync)
279 {
280 struct afs_vnode *vnode = fc->vnode;
281 struct afs_call *call;
282 struct afs_net *net = afs_v2net(vnode);
283 __be32 *bp;
284
285 if (test_bit(AFS_SERVER_FL_IS_YFS, &fc->cbi->server->flags))
286 return yfs_fs_fetch_file_status(fc, scb, volsync);
287
288 _enter(",%x,{%llx:%llu},,",
289 key_serial(fc->key), vnode->fid.vid, vnode->fid.vnode);
290
291 call = afs_alloc_flat_call(net, &afs_RXFSFetchStatus_vnode,
292 16, (21 + 3 + 6) * 4);
293 if (!call) {
294 fc->ac.error = -ENOMEM;
295 return -ENOMEM;
296 }
297
298 call->key = fc->key;
299 call->out_scb = scb;
300 call->out_volsync = volsync;
301
302 /* marshall the parameters */
303 bp = call->request;
304 bp[0] = htonl(FSFETCHSTATUS);
305 bp[1] = htonl(vnode->fid.vid);
306 bp[2] = htonl(vnode->fid.vnode);
307 bp[3] = htonl(vnode->fid.unique);
308
309 afs_use_fs_server(call, fc->cbi);
310 trace_afs_make_fs_call(call, &vnode->fid);
311
312 afs_set_fc_call(call, fc);
313 afs_make_call(&fc->ac, call, GFP_NOFS);
314 return afs_wait_for_call_to_complete(call, &fc->ac);
315 }
316
317 /*
318 * deliver reply data to an FS.FetchData
319 */
320 static int afs_deliver_fs_fetch_data(struct afs_call *call)
321 {
322 struct afs_read *req = call->read_request;
323 const __be32 *bp;
324 unsigned int size;
325 int ret;
326
327 _enter("{%u,%zu/%llu}",
328 call->unmarshall, iov_iter_count(&call->iter), req->actual_len);
329
330 switch (call->unmarshall) {
331 case 0:
332 req->actual_len = 0;
333 req->index = 0;
334 req->offset = req->pos & (PAGE_SIZE - 1);
335 call->unmarshall++;
336 if (call->operation_ID == FSFETCHDATA64) {
337 afs_extract_to_tmp64(call);
338 } else {
339 call->tmp_u = htonl(0);
340 afs_extract_to_tmp(call);
341 }
342
343 /* Fall through - and extract the returned data length */
344 case 1:
345 _debug("extract data length");
346 ret = afs_extract_data(call, true);
347 if (ret < 0)
348 return ret;
349
350 req->actual_len = be64_to_cpu(call->tmp64);
351 _debug("DATA length: %llu", req->actual_len);
352 req->remain = min(req->len, req->actual_len);
353 if (req->remain == 0)
354 goto no_more_data;
355
356 call->unmarshall++;
357
358 begin_page:
359 ASSERTCMP(req->index, <, req->nr_pages);
360 if (req->remain > PAGE_SIZE - req->offset)
361 size = PAGE_SIZE - req->offset;
362 else
363 size = req->remain;
364 call->bvec[0].bv_len = size;
365 call->bvec[0].bv_offset = req->offset;
366 call->bvec[0].bv_page = req->pages[req->index];
367 iov_iter_bvec(&call->iter, READ, call->bvec, 1, size);
368 ASSERTCMP(size, <=, PAGE_SIZE);
369
370 /* Fall through - and extract the returned data */
371 case 2:
372 _debug("extract data %zu/%llu",
373 iov_iter_count(&call->iter), req->remain);
374
375 ret = afs_extract_data(call, true);
376 if (ret < 0)
377 return ret;
378 req->remain -= call->bvec[0].bv_len;
379 req->offset += call->bvec[0].bv_len;
380 ASSERTCMP(req->offset, <=, PAGE_SIZE);
381 if (req->offset == PAGE_SIZE) {
382 req->offset = 0;
383 if (req->page_done)
384 req->page_done(req);
385 req->index++;
386 if (req->remain > 0)
387 goto begin_page;
388 }
389
390 ASSERTCMP(req->remain, ==, 0);
391 if (req->actual_len <= req->len)
392 goto no_more_data;
393
394 /* Discard any excess data the server gave us */
395 iov_iter_discard(&call->iter, READ, req->actual_len - req->len);
396 call->unmarshall = 3;
397
398 /* Fall through */
399 case 3:
400 _debug("extract discard %zu/%llu",
401 iov_iter_count(&call->iter), req->actual_len - req->len);
402
403 ret = afs_extract_data(call, true);
404 if (ret < 0)
405 return ret;
406
407 no_more_data:
408 call->unmarshall = 4;
409 afs_extract_to_buf(call, (21 + 3 + 6) * 4);
410
411 /* Fall through - and extract the metadata */
412 case 4:
413 ret = afs_extract_data(call, false);
414 if (ret < 0)
415 return ret;
416
417 bp = call->buffer;
418 ret = xdr_decode_AFSFetchStatus(&bp, call, call->out_scb);
419 if (ret < 0)
420 return ret;
421 xdr_decode_AFSCallBack(&bp, call, call->out_scb);
422 xdr_decode_AFSVolSync(&bp, call->out_volsync);
423
424 req->data_version = call->out_scb->status.data_version;
425 req->file_size = call->out_scb->status.size;
426
427 call->unmarshall++;
428
429 case 5:
430 break;
431 }
432
433 for (; req->index < req->nr_pages; req->index++) {
434 if (req->offset < PAGE_SIZE)
435 zero_user_segment(req->pages[req->index],
436 req->offset, PAGE_SIZE);
437 if (req->page_done)
438 req->page_done(req);
439 req->offset = 0;
440 }
441
442 _leave(" = 0 [done]");
443 return 0;
444 }
445
446 static void afs_fetch_data_destructor(struct afs_call *call)
447 {
448 struct afs_read *req = call->read_request;
449
450 afs_put_read(req);
451 afs_flat_call_destructor(call);
452 }
453
454 /*
455 * FS.FetchData operation type
456 */
457 static const struct afs_call_type afs_RXFSFetchData = {
458 .name = "FS.FetchData",
459 .op = afs_FS_FetchData,
460 .deliver = afs_deliver_fs_fetch_data,
461 .destructor = afs_fetch_data_destructor,
462 };
463
464 static const struct afs_call_type afs_RXFSFetchData64 = {
465 .name = "FS.FetchData64",
466 .op = afs_FS_FetchData64,
467 .deliver = afs_deliver_fs_fetch_data,
468 .destructor = afs_fetch_data_destructor,
469 };
470
471 /*
472 * fetch data from a very large file
473 */
474 static int afs_fs_fetch_data64(struct afs_fs_cursor *fc,
475 struct afs_status_cb *scb,
476 struct afs_read *req)
477 {
478 struct afs_vnode *vnode = fc->vnode;
479 struct afs_call *call;
480 struct afs_net *net = afs_v2net(vnode);
481 __be32 *bp;
482
483 _enter("");
484
485 call = afs_alloc_flat_call(net, &afs_RXFSFetchData64, 32, (21 + 3 + 6) * 4);
486 if (!call)
487 return -ENOMEM;
488
489 call->key = fc->key;
490 call->out_scb = scb;
491 call->out_volsync = NULL;
492 call->read_request = req;
493
494 /* marshall the parameters */
495 bp = call->request;
496 bp[0] = htonl(FSFETCHDATA64);
497 bp[1] = htonl(vnode->fid.vid);
498 bp[2] = htonl(vnode->fid.vnode);
499 bp[3] = htonl(vnode->fid.unique);
500 bp[4] = htonl(upper_32_bits(req->pos));
501 bp[5] = htonl(lower_32_bits(req->pos));
502 bp[6] = 0;
503 bp[7] = htonl(lower_32_bits(req->len));
504
505 refcount_inc(&req->usage);
506 afs_use_fs_server(call, fc->cbi);
507 trace_afs_make_fs_call(call, &vnode->fid);
508 afs_set_fc_call(call, fc);
509 afs_make_call(&fc->ac, call, GFP_NOFS);
510 return afs_wait_for_call_to_complete(call, &fc->ac);
511 }
512
513 /*
514 * fetch data from a file
515 */
516 int afs_fs_fetch_data(struct afs_fs_cursor *fc,
517 struct afs_status_cb *scb,
518 struct afs_read *req)
519 {
520 struct afs_vnode *vnode = fc->vnode;
521 struct afs_call *call;
522 struct afs_net *net = afs_v2net(vnode);
523 __be32 *bp;
524
525 if (test_bit(AFS_SERVER_FL_IS_YFS, &fc->cbi->server->flags))
526 return yfs_fs_fetch_data(fc, scb, req);
527
528 if (upper_32_bits(req->pos) ||
529 upper_32_bits(req->len) ||
530 upper_32_bits(req->pos + req->len))
531 return afs_fs_fetch_data64(fc, scb, req);
532
533 _enter("");
534
535 call = afs_alloc_flat_call(net, &afs_RXFSFetchData, 24, (21 + 3 + 6) * 4);
536 if (!call)
537 return -ENOMEM;
538
539 call->key = fc->key;
540 call->out_scb = scb;
541 call->out_volsync = NULL;
542 call->read_request = req;
543
544 /* marshall the parameters */
545 bp = call->request;
546 bp[0] = htonl(FSFETCHDATA);
547 bp[1] = htonl(vnode->fid.vid);
548 bp[2] = htonl(vnode->fid.vnode);
549 bp[3] = htonl(vnode->fid.unique);
550 bp[4] = htonl(lower_32_bits(req->pos));
551 bp[5] = htonl(lower_32_bits(req->len));
552
553 refcount_inc(&req->usage);
554 afs_use_fs_server(call, fc->cbi);
555 trace_afs_make_fs_call(call, &vnode->fid);
556 afs_set_fc_call(call, fc);
557 afs_make_call(&fc->ac, call, GFP_NOFS);
558 return afs_wait_for_call_to_complete(call, &fc->ac);
559 }
560
561 /*
562 * deliver reply data to an FS.CreateFile or an FS.MakeDir
563 */
564 static int afs_deliver_fs_create_vnode(struct afs_call *call)
565 {
566 const __be32 *bp;
567 int ret;
568
569 ret = afs_transfer_reply(call);
570 if (ret < 0)
571 return ret;
572
573 /* unmarshall the reply once we've received all of it */
574 bp = call->buffer;
575 xdr_decode_AFSFid(&bp, call->out_fid);
576 ret = xdr_decode_AFSFetchStatus(&bp, call, call->out_scb);
577 if (ret < 0)
578 return ret;
579 ret = xdr_decode_AFSFetchStatus(&bp, call, call->out_dir_scb);
580 if (ret < 0)
581 return ret;
582 xdr_decode_AFSCallBack(&bp, call, call->out_scb);
583 xdr_decode_AFSVolSync(&bp, call->out_volsync);
584
585 _leave(" = 0 [done]");
586 return 0;
587 }
588
589 /*
590 * FS.CreateFile and FS.MakeDir operation type
591 */
592 static const struct afs_call_type afs_RXFSCreateFile = {
593 .name = "FS.CreateFile",
594 .op = afs_FS_CreateFile,
595 .deliver = afs_deliver_fs_create_vnode,
596 .destructor = afs_flat_call_destructor,
597 };
598
599 static const struct afs_call_type afs_RXFSMakeDir = {
600 .name = "FS.MakeDir",
601 .op = afs_FS_MakeDir,
602 .deliver = afs_deliver_fs_create_vnode,
603 .destructor = afs_flat_call_destructor,
604 };
605
606 /*
607 * create a file or make a directory
608 */
609 int afs_fs_create(struct afs_fs_cursor *fc,
610 const char *name,
611 umode_t mode,
612 struct afs_status_cb *dvnode_scb,
613 struct afs_fid *newfid,
614 struct afs_status_cb *new_scb)
615 {
616 struct afs_vnode *dvnode = fc->vnode;
617 struct afs_call *call;
618 struct afs_net *net = afs_v2net(dvnode);
619 size_t namesz, reqsz, padsz;
620 __be32 *bp;
621
622 if (test_bit(AFS_SERVER_FL_IS_YFS, &fc->cbi->server->flags)){
623 if (S_ISDIR(mode))
624 return yfs_fs_make_dir(fc, name, mode, dvnode_scb,
625 newfid, new_scb);
626 else
627 return yfs_fs_create_file(fc, name, mode, dvnode_scb,
628 newfid, new_scb);
629 }
630
631 _enter("");
632
633 namesz = strlen(name);
634 padsz = (4 - (namesz & 3)) & 3;
635 reqsz = (5 * 4) + namesz + padsz + (6 * 4);
636
637 call = afs_alloc_flat_call(
638 net, S_ISDIR(mode) ? &afs_RXFSMakeDir : &afs_RXFSCreateFile,
639 reqsz, (3 + 21 + 21 + 3 + 6) * 4);
640 if (!call)
641 return -ENOMEM;
642
643 call->key = fc->key;
644 call->out_dir_scb = dvnode_scb;
645 call->out_fid = newfid;
646 call->out_scb = new_scb;
647
648 /* marshall the parameters */
649 bp = call->request;
650 *bp++ = htonl(S_ISDIR(mode) ? FSMAKEDIR : FSCREATEFILE);
651 *bp++ = htonl(dvnode->fid.vid);
652 *bp++ = htonl(dvnode->fid.vnode);
653 *bp++ = htonl(dvnode->fid.unique);
654 *bp++ = htonl(namesz);
655 memcpy(bp, name, namesz);
656 bp = (void *) bp + namesz;
657 if (padsz > 0) {
658 memset(bp, 0, padsz);
659 bp = (void *) bp + padsz;
660 }
661 *bp++ = htonl(AFS_SET_MODE | AFS_SET_MTIME);
662 *bp++ = htonl(dvnode->vfs_inode.i_mtime.tv_sec); /* mtime */
663 *bp++ = 0; /* owner */
664 *bp++ = 0; /* group */
665 *bp++ = htonl(mode & S_IALLUGO); /* unix mode */
666 *bp++ = 0; /* segment size */
667
668 afs_use_fs_server(call, fc->cbi);
669 trace_afs_make_fs_call1(call, &dvnode->fid, name);
670 afs_set_fc_call(call, fc);
671 afs_make_call(&fc->ac, call, GFP_NOFS);
672 return afs_wait_for_call_to_complete(call, &fc->ac);
673 }
674
675 /*
676 * Deliver reply data to any operation that returns directory status and volume
677 * sync.
678 */
679 static int afs_deliver_fs_dir_status_and_vol(struct afs_call *call)
680 {
681 const __be32 *bp;
682 int ret;
683
684 ret = afs_transfer_reply(call);
685 if (ret < 0)
686 return ret;
687
688 /* unmarshall the reply once we've received all of it */
689 bp = call->buffer;
690 ret = xdr_decode_AFSFetchStatus(&bp, call, call->out_dir_scb);
691 if (ret < 0)
692 return ret;
693 xdr_decode_AFSVolSync(&bp, call->out_volsync);
694
695 _leave(" = 0 [done]");
696 return 0;
697 }
698
699 /*
700 * FS.RemoveDir/FS.RemoveFile operation type
701 */
702 static const struct afs_call_type afs_RXFSRemoveFile = {
703 .name = "FS.RemoveFile",
704 .op = afs_FS_RemoveFile,
705 .deliver = afs_deliver_fs_dir_status_and_vol,
706 .destructor = afs_flat_call_destructor,
707 };
708
709 static const struct afs_call_type afs_RXFSRemoveDir = {
710 .name = "FS.RemoveDir",
711 .op = afs_FS_RemoveDir,
712 .deliver = afs_deliver_fs_dir_status_and_vol,
713 .destructor = afs_flat_call_destructor,
714 };
715
716 /*
717 * remove a file or directory
718 */
719 int afs_fs_remove(struct afs_fs_cursor *fc, struct afs_vnode *vnode,
720 const char *name, bool isdir, struct afs_status_cb *dvnode_scb)
721 {
722 struct afs_vnode *dvnode = fc->vnode;
723 struct afs_call *call;
724 struct afs_net *net = afs_v2net(dvnode);
725 size_t namesz, reqsz, padsz;
726 __be32 *bp;
727
728 if (test_bit(AFS_SERVER_FL_IS_YFS, &fc->cbi->server->flags))
729 return yfs_fs_remove(fc, vnode, name, isdir, dvnode_scb);
730
731 _enter("");
732
733 namesz = strlen(name);
734 padsz = (4 - (namesz & 3)) & 3;
735 reqsz = (5 * 4) + namesz + padsz;
736
737 call = afs_alloc_flat_call(
738 net, isdir ? &afs_RXFSRemoveDir : &afs_RXFSRemoveFile,
739 reqsz, (21 + 6) * 4);
740 if (!call)
741 return -ENOMEM;
742
743 call->key = fc->key;
744 call->out_dir_scb = dvnode_scb;
745
746 /* marshall the parameters */
747 bp = call->request;
748 *bp++ = htonl(isdir ? FSREMOVEDIR : FSREMOVEFILE);
749 *bp++ = htonl(dvnode->fid.vid);
750 *bp++ = htonl(dvnode->fid.vnode);
751 *bp++ = htonl(dvnode->fid.unique);
752 *bp++ = htonl(namesz);
753 memcpy(bp, name, namesz);
754 bp = (void *) bp + namesz;
755 if (padsz > 0) {
756 memset(bp, 0, padsz);
757 bp = (void *) bp + padsz;
758 }
759
760 afs_use_fs_server(call, fc->cbi);
761 trace_afs_make_fs_call1(call, &dvnode->fid, name);
762 afs_set_fc_call(call, fc);
763 afs_make_call(&fc->ac, call, GFP_NOFS);
764 return afs_wait_for_call_to_complete(call, &fc->ac);
765 }
766
767 /*
768 * deliver reply data to an FS.Link
769 */
770 static int afs_deliver_fs_link(struct afs_call *call)
771 {
772 const __be32 *bp;
773 int ret;
774
775 _enter("{%u}", call->unmarshall);
776
777 ret = afs_transfer_reply(call);
778 if (ret < 0)
779 return ret;
780
781 /* unmarshall the reply once we've received all of it */
782 bp = call->buffer;
783 ret = xdr_decode_AFSFetchStatus(&bp, call, call->out_scb);
784 if (ret < 0)
785 return ret;
786 ret = xdr_decode_AFSFetchStatus(&bp, call, call->out_dir_scb);
787 if (ret < 0)
788 return ret;
789 xdr_decode_AFSVolSync(&bp, call->out_volsync);
790
791 _leave(" = 0 [done]");
792 return 0;
793 }
794
795 /*
796 * FS.Link operation type
797 */
798 static const struct afs_call_type afs_RXFSLink = {
799 .name = "FS.Link",
800 .op = afs_FS_Link,
801 .deliver = afs_deliver_fs_link,
802 .destructor = afs_flat_call_destructor,
803 };
804
805 /*
806 * make a hard link
807 */
808 int afs_fs_link(struct afs_fs_cursor *fc, struct afs_vnode *vnode,
809 const char *name,
810 struct afs_status_cb *dvnode_scb,
811 struct afs_status_cb *vnode_scb)
812 {
813 struct afs_vnode *dvnode = fc->vnode;
814 struct afs_call *call;
815 struct afs_net *net = afs_v2net(vnode);
816 size_t namesz, reqsz, padsz;
817 __be32 *bp;
818
819 if (test_bit(AFS_SERVER_FL_IS_YFS, &fc->cbi->server->flags))
820 return yfs_fs_link(fc, vnode, name, dvnode_scb, vnode_scb);
821
822 _enter("");
823
824 namesz = strlen(name);
825 padsz = (4 - (namesz & 3)) & 3;
826 reqsz = (5 * 4) + namesz + padsz + (3 * 4);
827
828 call = afs_alloc_flat_call(net, &afs_RXFSLink, reqsz, (21 + 21 + 6) * 4);
829 if (!call)
830 return -ENOMEM;
831
832 call->key = fc->key;
833 call->out_dir_scb = dvnode_scb;
834 call->out_scb = vnode_scb;
835
836 /* marshall the parameters */
837 bp = call->request;
838 *bp++ = htonl(FSLINK);
839 *bp++ = htonl(dvnode->fid.vid);
840 *bp++ = htonl(dvnode->fid.vnode);
841 *bp++ = htonl(dvnode->fid.unique);
842 *bp++ = htonl(namesz);
843 memcpy(bp, name, namesz);
844 bp = (void *) bp + namesz;
845 if (padsz > 0) {
846 memset(bp, 0, padsz);
847 bp = (void *) bp + padsz;
848 }
849 *bp++ = htonl(vnode->fid.vid);
850 *bp++ = htonl(vnode->fid.vnode);
851 *bp++ = htonl(vnode->fid.unique);
852
853 afs_use_fs_server(call, fc->cbi);
854 trace_afs_make_fs_call1(call, &vnode->fid, name);
855 afs_set_fc_call(call, fc);
856 afs_make_call(&fc->ac, call, GFP_NOFS);
857 return afs_wait_for_call_to_complete(call, &fc->ac);
858 }
859
860 /*
861 * deliver reply data to an FS.Symlink
862 */
863 static int afs_deliver_fs_symlink(struct afs_call *call)
864 {
865 const __be32 *bp;
866 int ret;
867
868 _enter("{%u}", call->unmarshall);
869
870 ret = afs_transfer_reply(call);
871 if (ret < 0)
872 return ret;
873
874 /* unmarshall the reply once we've received all of it */
875 bp = call->buffer;
876 xdr_decode_AFSFid(&bp, call->out_fid);
877 ret = xdr_decode_AFSFetchStatus(&bp, call, call->out_scb);
878 if (ret < 0)
879 return ret;
880 ret = xdr_decode_AFSFetchStatus(&bp, call, call->out_dir_scb);
881 if (ret < 0)
882 return ret;
883 xdr_decode_AFSVolSync(&bp, call->out_volsync);
884
885 _leave(" = 0 [done]");
886 return 0;
887 }
888
889 /*
890 * FS.Symlink operation type
891 */
892 static const struct afs_call_type afs_RXFSSymlink = {
893 .name = "FS.Symlink",
894 .op = afs_FS_Symlink,
895 .deliver = afs_deliver_fs_symlink,
896 .destructor = afs_flat_call_destructor,
897 };
898
899 /*
900 * create a symbolic link
901 */
902 int afs_fs_symlink(struct afs_fs_cursor *fc,
903 const char *name,
904 const char *contents,
905 struct afs_status_cb *dvnode_scb,
906 struct afs_fid *newfid,
907 struct afs_status_cb *new_scb)
908 {
909 struct afs_vnode *dvnode = fc->vnode;
910 struct afs_call *call;
911 struct afs_net *net = afs_v2net(dvnode);
912 size_t namesz, reqsz, padsz, c_namesz, c_padsz;
913 __be32 *bp;
914
915 if (test_bit(AFS_SERVER_FL_IS_YFS, &fc->cbi->server->flags))
916 return yfs_fs_symlink(fc, name, contents, dvnode_scb,
917 newfid, new_scb);
918
919 _enter("");
920
921 namesz = strlen(name);
922 padsz = (4 - (namesz & 3)) & 3;
923
924 c_namesz = strlen(contents);
925 c_padsz = (4 - (c_namesz & 3)) & 3;
926
927 reqsz = (6 * 4) + namesz + padsz + c_namesz + c_padsz + (6 * 4);
928
929 call = afs_alloc_flat_call(net, &afs_RXFSSymlink, reqsz,
930 (3 + 21 + 21 + 6) * 4);
931 if (!call)
932 return -ENOMEM;
933
934 call->key = fc->key;
935 call->out_dir_scb = dvnode_scb;
936 call->out_fid = newfid;
937 call->out_scb = new_scb;
938
939 /* marshall the parameters */
940 bp = call->request;
941 *bp++ = htonl(FSSYMLINK);
942 *bp++ = htonl(dvnode->fid.vid);
943 *bp++ = htonl(dvnode->fid.vnode);
944 *bp++ = htonl(dvnode->fid.unique);
945 *bp++ = htonl(namesz);
946 memcpy(bp, name, namesz);
947 bp = (void *) bp + namesz;
948 if (padsz > 0) {
949 memset(bp, 0, padsz);
950 bp = (void *) bp + padsz;
951 }
952 *bp++ = htonl(c_namesz);
953 memcpy(bp, contents, c_namesz);
954 bp = (void *) bp + c_namesz;
955 if (c_padsz > 0) {
956 memset(bp, 0, c_padsz);
957 bp = (void *) bp + c_padsz;
958 }
959 *bp++ = htonl(AFS_SET_MODE | AFS_SET_MTIME);
960 *bp++ = htonl(dvnode->vfs_inode.i_mtime.tv_sec); /* mtime */
961 *bp++ = 0; /* owner */
962 *bp++ = 0; /* group */
963 *bp++ = htonl(S_IRWXUGO); /* unix mode */
964 *bp++ = 0; /* segment size */
965
966 afs_use_fs_server(call, fc->cbi);
967 trace_afs_make_fs_call1(call, &dvnode->fid, name);
968 afs_set_fc_call(call, fc);
969 afs_make_call(&fc->ac, call, GFP_NOFS);
970 return afs_wait_for_call_to_complete(call, &fc->ac);
971 }
972
973 /*
974 * deliver reply data to an FS.Rename
975 */
976 static int afs_deliver_fs_rename(struct afs_call *call)
977 {
978 const __be32 *bp;
979 int ret;
980
981 ret = afs_transfer_reply(call);
982 if (ret < 0)
983 return ret;
984
985 /* unmarshall the reply once we've received all of it */
986 bp = call->buffer;
987 ret = xdr_decode_AFSFetchStatus(&bp, call, call->out_dir_scb);
988 if (ret < 0)
989 return ret;
990 if (call->out_dir_scb != call->out_scb) {
991 ret = xdr_decode_AFSFetchStatus(&bp, call, call->out_scb);
992 if (ret < 0)
993 return ret;
994 }
995 xdr_decode_AFSVolSync(&bp, call->out_volsync);
996
997 _leave(" = 0 [done]");
998 return 0;
999 }
1000
1001 /*
1002 * FS.Rename operation type
1003 */
1004 static const struct afs_call_type afs_RXFSRename = {
1005 .name = "FS.Rename",
1006 .op = afs_FS_Rename,
1007 .deliver = afs_deliver_fs_rename,
1008 .destructor = afs_flat_call_destructor,
1009 };
1010
1011 /*
1012 * Rename/move a file or directory.
1013 */
1014 int afs_fs_rename(struct afs_fs_cursor *fc,
1015 const char *orig_name,
1016 struct afs_vnode *new_dvnode,
1017 const char *new_name,
1018 struct afs_status_cb *orig_dvnode_scb,
1019 struct afs_status_cb *new_dvnode_scb)
1020 {
1021 struct afs_vnode *orig_dvnode = fc->vnode;
1022 struct afs_call *call;
1023 struct afs_net *net = afs_v2net(orig_dvnode);
1024 size_t reqsz, o_namesz, o_padsz, n_namesz, n_padsz;
1025 __be32 *bp;
1026
1027 if (test_bit(AFS_SERVER_FL_IS_YFS, &fc->cbi->server->flags))
1028 return yfs_fs_rename(fc, orig_name,
1029 new_dvnode, new_name,
1030 orig_dvnode_scb,
1031 new_dvnode_scb);
1032
1033 _enter("");
1034
1035 o_namesz = strlen(orig_name);
1036 o_padsz = (4 - (o_namesz & 3)) & 3;
1037
1038 n_namesz = strlen(new_name);
1039 n_padsz = (4 - (n_namesz & 3)) & 3;
1040
1041 reqsz = (4 * 4) +
1042 4 + o_namesz + o_padsz +
1043 (3 * 4) +
1044 4 + n_namesz + n_padsz;
1045
1046 call = afs_alloc_flat_call(net, &afs_RXFSRename, reqsz, (21 + 21 + 6) * 4);
1047 if (!call)
1048 return -ENOMEM;
1049
1050 call->key = fc->key;
1051 call->out_dir_scb = orig_dvnode_scb;
1052 call->out_scb = new_dvnode_scb;
1053
1054 /* marshall the parameters */
1055 bp = call->request;
1056 *bp++ = htonl(FSRENAME);
1057 *bp++ = htonl(orig_dvnode->fid.vid);
1058 *bp++ = htonl(orig_dvnode->fid.vnode);
1059 *bp++ = htonl(orig_dvnode->fid.unique);
1060 *bp++ = htonl(o_namesz);
1061 memcpy(bp, orig_name, o_namesz);
1062 bp = (void *) bp + o_namesz;
1063 if (o_padsz > 0) {
1064 memset(bp, 0, o_padsz);
1065 bp = (void *) bp + o_padsz;
1066 }
1067
1068 *bp++ = htonl(new_dvnode->fid.vid);
1069 *bp++ = htonl(new_dvnode->fid.vnode);
1070 *bp++ = htonl(new_dvnode->fid.unique);
1071 *bp++ = htonl(n_namesz);
1072 memcpy(bp, new_name, n_namesz);
1073 bp = (void *) bp + n_namesz;
1074 if (n_padsz > 0) {
1075 memset(bp, 0, n_padsz);
1076 bp = (void *) bp + n_padsz;
1077 }
1078
1079 afs_use_fs_server(call, fc->cbi);
1080 trace_afs_make_fs_call2(call, &orig_dvnode->fid, orig_name, new_name);
1081 afs_set_fc_call(call, fc);
1082 afs_make_call(&fc->ac, call, GFP_NOFS);
1083 return afs_wait_for_call_to_complete(call, &fc->ac);
1084 }
1085
1086 /*
1087 * deliver reply data to an FS.StoreData
1088 */
1089 static int afs_deliver_fs_store_data(struct afs_call *call)
1090 {
1091 const __be32 *bp;
1092 int ret;
1093
1094 _enter("");
1095
1096 ret = afs_transfer_reply(call);
1097 if (ret < 0)
1098 return ret;
1099
1100 /* unmarshall the reply once we've received all of it */
1101 bp = call->buffer;
1102 ret = xdr_decode_AFSFetchStatus(&bp, call, call->out_scb);
1103 if (ret < 0)
1104 return ret;
1105 xdr_decode_AFSVolSync(&bp, call->out_volsync);
1106
1107 _leave(" = 0 [done]");
1108 return 0;
1109 }
1110
1111 /*
1112 * FS.StoreData operation type
1113 */
1114 static const struct afs_call_type afs_RXFSStoreData = {
1115 .name = "FS.StoreData",
1116 .op = afs_FS_StoreData,
1117 .deliver = afs_deliver_fs_store_data,
1118 .destructor = afs_flat_call_destructor,
1119 };
1120
1121 static const struct afs_call_type afs_RXFSStoreData64 = {
1122 .name = "FS.StoreData64",
1123 .op = afs_FS_StoreData64,
1124 .deliver = afs_deliver_fs_store_data,
1125 .destructor = afs_flat_call_destructor,
1126 };
1127
1128 /*
1129 * store a set of pages to a very large file
1130 */
1131 static int afs_fs_store_data64(struct afs_fs_cursor *fc,
1132 struct address_space *mapping,
1133 pgoff_t first, pgoff_t last,
1134 unsigned offset, unsigned to,
1135 loff_t size, loff_t pos, loff_t i_size,
1136 struct afs_status_cb *scb)
1137 {
1138 struct afs_vnode *vnode = fc->vnode;
1139 struct afs_call *call;
1140 struct afs_net *net = afs_v2net(vnode);
1141 __be32 *bp;
1142
1143 _enter(",%x,{%llx:%llu},,",
1144 key_serial(fc->key), vnode->fid.vid, vnode->fid.vnode);
1145
1146 call = afs_alloc_flat_call(net, &afs_RXFSStoreData64,
1147 (4 + 6 + 3 * 2) * 4,
1148 (21 + 6) * 4);
1149 if (!call)
1150 return -ENOMEM;
1151
1152 call->key = fc->key;
1153 call->mapping = mapping;
1154 call->first = first;
1155 call->last = last;
1156 call->first_offset = offset;
1157 call->last_to = to;
1158 call->send_pages = true;
1159 call->out_scb = scb;
1160
1161 /* marshall the parameters */
1162 bp = call->request;
1163 *bp++ = htonl(FSSTOREDATA64);
1164 *bp++ = htonl(vnode->fid.vid);
1165 *bp++ = htonl(vnode->fid.vnode);
1166 *bp++ = htonl(vnode->fid.unique);
1167
1168 *bp++ = htonl(AFS_SET_MTIME); /* mask */
1169 *bp++ = htonl(vnode->vfs_inode.i_mtime.tv_sec); /* mtime */
1170 *bp++ = 0; /* owner */
1171 *bp++ = 0; /* group */
1172 *bp++ = 0; /* unix mode */
1173 *bp++ = 0; /* segment size */
1174
1175 *bp++ = htonl(pos >> 32);
1176 *bp++ = htonl((u32) pos);
1177 *bp++ = htonl(size >> 32);
1178 *bp++ = htonl((u32) size);
1179 *bp++ = htonl(i_size >> 32);
1180 *bp++ = htonl((u32) i_size);
1181
1182 trace_afs_make_fs_call(call, &vnode->fid);
1183 afs_set_fc_call(call, fc);
1184 afs_make_call(&fc->ac, call, GFP_NOFS);
1185 return afs_wait_for_call_to_complete(call, &fc->ac);
1186 }
1187
1188 /*
1189 * store a set of pages
1190 */
1191 int afs_fs_store_data(struct afs_fs_cursor *fc, struct address_space *mapping,
1192 pgoff_t first, pgoff_t last,
1193 unsigned offset, unsigned to,
1194 struct afs_status_cb *scb)
1195 {
1196 struct afs_vnode *vnode = fc->vnode;
1197 struct afs_call *call;
1198 struct afs_net *net = afs_v2net(vnode);
1199 loff_t size, pos, i_size;
1200 __be32 *bp;
1201
1202 if (test_bit(AFS_SERVER_FL_IS_YFS, &fc->cbi->server->flags))
1203 return yfs_fs_store_data(fc, mapping, first, last, offset, to, scb);
1204
1205 _enter(",%x,{%llx:%llu},,",
1206 key_serial(fc->key), vnode->fid.vid, vnode->fid.vnode);
1207
1208 size = (loff_t)to - (loff_t)offset;
1209 if (first != last)
1210 size += (loff_t)(last - first) << PAGE_SHIFT;
1211 pos = (loff_t)first << PAGE_SHIFT;
1212 pos += offset;
1213
1214 i_size = i_size_read(&vnode->vfs_inode);
1215 if (pos + size > i_size)
1216 i_size = size + pos;
1217
1218 _debug("size %llx, at %llx, i_size %llx",
1219 (unsigned long long) size, (unsigned long long) pos,
1220 (unsigned long long) i_size);
1221
1222 if (pos >> 32 || i_size >> 32 || size >> 32 || (pos + size) >> 32)
1223 return afs_fs_store_data64(fc, mapping, first, last, offset, to,
1224 size, pos, i_size, scb);
1225
1226 call = afs_alloc_flat_call(net, &afs_RXFSStoreData,
1227 (4 + 6 + 3) * 4,
1228 (21 + 6) * 4);
1229 if (!call)
1230 return -ENOMEM;
1231
1232 call->key = fc->key;
1233 call->mapping = mapping;
1234 call->first = first;
1235 call->last = last;
1236 call->first_offset = offset;
1237 call->last_to = to;
1238 call->send_pages = true;
1239 call->out_scb = scb;
1240
1241 /* marshall the parameters */
1242 bp = call->request;
1243 *bp++ = htonl(FSSTOREDATA);
1244 *bp++ = htonl(vnode->fid.vid);
1245 *bp++ = htonl(vnode->fid.vnode);
1246 *bp++ = htonl(vnode->fid.unique);
1247
1248 *bp++ = htonl(AFS_SET_MTIME); /* mask */
1249 *bp++ = htonl(vnode->vfs_inode.i_mtime.tv_sec); /* mtime */
1250 *bp++ = 0; /* owner */
1251 *bp++ = 0; /* group */
1252 *bp++ = 0; /* unix mode */
1253 *bp++ = 0; /* segment size */
1254
1255 *bp++ = htonl(pos);
1256 *bp++ = htonl(size);
1257 *bp++ = htonl(i_size);
1258
1259 afs_use_fs_server(call, fc->cbi);
1260 trace_afs_make_fs_call(call, &vnode->fid);
1261 afs_set_fc_call(call, fc);
1262 afs_make_call(&fc->ac, call, GFP_NOFS);
1263 return afs_wait_for_call_to_complete(call, &fc->ac);
1264 }
1265
1266 /*
1267 * deliver reply data to an FS.StoreStatus
1268 */
1269 static int afs_deliver_fs_store_status(struct afs_call *call)
1270 {
1271 const __be32 *bp;
1272 int ret;
1273
1274 _enter("");
1275
1276 ret = afs_transfer_reply(call);
1277 if (ret < 0)
1278 return ret;
1279
1280 /* unmarshall the reply once we've received all of it */
1281 bp = call->buffer;
1282 ret = xdr_decode_AFSFetchStatus(&bp, call, call->out_scb);
1283 if (ret < 0)
1284 return ret;
1285 xdr_decode_AFSVolSync(&bp, call->out_volsync);
1286
1287 _leave(" = 0 [done]");
1288 return 0;
1289 }
1290
1291 /*
1292 * FS.StoreStatus operation type
1293 */
1294 static const struct afs_call_type afs_RXFSStoreStatus = {
1295 .name = "FS.StoreStatus",
1296 .op = afs_FS_StoreStatus,
1297 .deliver = afs_deliver_fs_store_status,
1298 .destructor = afs_flat_call_destructor,
1299 };
1300
1301 static const struct afs_call_type afs_RXFSStoreData_as_Status = {
1302 .name = "FS.StoreData",
1303 .op = afs_FS_StoreData,
1304 .deliver = afs_deliver_fs_store_status,
1305 .destructor = afs_flat_call_destructor,
1306 };
1307
1308 static const struct afs_call_type afs_RXFSStoreData64_as_Status = {
1309 .name = "FS.StoreData64",
1310 .op = afs_FS_StoreData64,
1311 .deliver = afs_deliver_fs_store_status,
1312 .destructor = afs_flat_call_destructor,
1313 };
1314
1315 /*
1316 * set the attributes on a very large file, using FS.StoreData rather than
1317 * FS.StoreStatus so as to alter the file size also
1318 */
1319 static int afs_fs_setattr_size64(struct afs_fs_cursor *fc, struct iattr *attr,
1320 struct afs_status_cb *scb)
1321 {
1322 struct afs_vnode *vnode = fc->vnode;
1323 struct afs_call *call;
1324 struct afs_net *net = afs_v2net(vnode);
1325 __be32 *bp;
1326
1327 _enter(",%x,{%llx:%llu},,",
1328 key_serial(fc->key), vnode->fid.vid, vnode->fid.vnode);
1329
1330 ASSERT(attr->ia_valid & ATTR_SIZE);
1331
1332 call = afs_alloc_flat_call(net, &afs_RXFSStoreData64_as_Status,
1333 (4 + 6 + 3 * 2) * 4,
1334 (21 + 6) * 4);
1335 if (!call)
1336 return -ENOMEM;
1337
1338 call->key = fc->key;
1339 call->out_scb = scb;
1340
1341 /* marshall the parameters */
1342 bp = call->request;
1343 *bp++ = htonl(FSSTOREDATA64);
1344 *bp++ = htonl(vnode->fid.vid);
1345 *bp++ = htonl(vnode->fid.vnode);
1346 *bp++ = htonl(vnode->fid.unique);
1347
1348 xdr_encode_AFS_StoreStatus(&bp, attr);
1349
1350 *bp++ = htonl(attr->ia_size >> 32); /* position of start of write */
1351 *bp++ = htonl((u32) attr->ia_size);
1352 *bp++ = 0; /* size of write */
1353 *bp++ = 0;
1354 *bp++ = htonl(attr->ia_size >> 32); /* new file length */
1355 *bp++ = htonl((u32) attr->ia_size);
1356
1357 afs_use_fs_server(call, fc->cbi);
1358 trace_afs_make_fs_call(call, &vnode->fid);
1359 afs_set_fc_call(call, fc);
1360 afs_make_call(&fc->ac, call, GFP_NOFS);
1361 return afs_wait_for_call_to_complete(call, &fc->ac);
1362 }
1363
1364 /*
1365 * set the attributes on a file, using FS.StoreData rather than FS.StoreStatus
1366 * so as to alter the file size also
1367 */
1368 static int afs_fs_setattr_size(struct afs_fs_cursor *fc, struct iattr *attr,
1369 struct afs_status_cb *scb)
1370 {
1371 struct afs_vnode *vnode = fc->vnode;
1372 struct afs_call *call;
1373 struct afs_net *net = afs_v2net(vnode);
1374 __be32 *bp;
1375
1376 _enter(",%x,{%llx:%llu},,",
1377 key_serial(fc->key), vnode->fid.vid, vnode->fid.vnode);
1378
1379 ASSERT(attr->ia_valid & ATTR_SIZE);
1380 if (attr->ia_size >> 32)
1381 return afs_fs_setattr_size64(fc, attr, scb);
1382
1383 call = afs_alloc_flat_call(net, &afs_RXFSStoreData_as_Status,
1384 (4 + 6 + 3) * 4,
1385 (21 + 6) * 4);
1386 if (!call)
1387 return -ENOMEM;
1388
1389 call->key = fc->key;
1390 call->out_scb = scb;
1391
1392 /* marshall the parameters */
1393 bp = call->request;
1394 *bp++ = htonl(FSSTOREDATA);
1395 *bp++ = htonl(vnode->fid.vid);
1396 *bp++ = htonl(vnode->fid.vnode);
1397 *bp++ = htonl(vnode->fid.unique);
1398
1399 xdr_encode_AFS_StoreStatus(&bp, attr);
1400
1401 *bp++ = htonl(attr->ia_size); /* position of start of write */
1402 *bp++ = 0; /* size of write */
1403 *bp++ = htonl(attr->ia_size); /* new file length */
1404
1405 afs_use_fs_server(call, fc->cbi);
1406 trace_afs_make_fs_call(call, &vnode->fid);
1407 afs_set_fc_call(call, fc);
1408 afs_make_call(&fc->ac, call, GFP_NOFS);
1409 return afs_wait_for_call_to_complete(call, &fc->ac);
1410 }
1411
1412 /*
1413 * set the attributes on a file, using FS.StoreData if there's a change in file
1414 * size, and FS.StoreStatus otherwise
1415 */
1416 int afs_fs_setattr(struct afs_fs_cursor *fc, struct iattr *attr,
1417 struct afs_status_cb *scb)
1418 {
1419 struct afs_vnode *vnode = fc->vnode;
1420 struct afs_call *call;
1421 struct afs_net *net = afs_v2net(vnode);
1422 __be32 *bp;
1423
1424 if (test_bit(AFS_SERVER_FL_IS_YFS, &fc->cbi->server->flags))
1425 return yfs_fs_setattr(fc, attr, scb);
1426
1427 if (attr->ia_valid & ATTR_SIZE)
1428 return afs_fs_setattr_size(fc, attr, scb);
1429
1430 _enter(",%x,{%llx:%llu},,",
1431 key_serial(fc->key), vnode->fid.vid, vnode->fid.vnode);
1432
1433 call = afs_alloc_flat_call(net, &afs_RXFSStoreStatus,
1434 (4 + 6) * 4,
1435 (21 + 6) * 4);
1436 if (!call)
1437 return -ENOMEM;
1438
1439 call->key = fc->key;
1440 call->out_scb = scb;
1441
1442 /* marshall the parameters */
1443 bp = call->request;
1444 *bp++ = htonl(FSSTORESTATUS);
1445 *bp++ = htonl(vnode->fid.vid);
1446 *bp++ = htonl(vnode->fid.vnode);
1447 *bp++ = htonl(vnode->fid.unique);
1448
1449 xdr_encode_AFS_StoreStatus(&bp, attr);
1450
1451 afs_use_fs_server(call, fc->cbi);
1452 trace_afs_make_fs_call(call, &vnode->fid);
1453 afs_set_fc_call(call, fc);
1454 afs_make_call(&fc->ac, call, GFP_NOFS);
1455 return afs_wait_for_call_to_complete(call, &fc->ac);
1456 }
1457
1458 /*
1459 * deliver reply data to an FS.GetVolumeStatus
1460 */
1461 static int afs_deliver_fs_get_volume_status(struct afs_call *call)
1462 {
1463 const __be32 *bp;
1464 char *p;
1465 u32 size;
1466 int ret;
1467
1468 _enter("{%u}", call->unmarshall);
1469
1470 switch (call->unmarshall) {
1471 case 0:
1472 call->unmarshall++;
1473 afs_extract_to_buf(call, 12 * 4);
1474
1475 /* Fall through - and extract the returned status record */
1476 case 1:
1477 _debug("extract status");
1478 ret = afs_extract_data(call, true);
1479 if (ret < 0)
1480 return ret;
1481
1482 bp = call->buffer;
1483 xdr_decode_AFSFetchVolumeStatus(&bp, call->out_volstatus);
1484 call->unmarshall++;
1485 afs_extract_to_tmp(call);
1486
1487 /* Fall through - and extract the volume name length */
1488 case 2:
1489 ret = afs_extract_data(call, true);
1490 if (ret < 0)
1491 return ret;
1492
1493 call->count = ntohl(call->tmp);
1494 _debug("volname length: %u", call->count);
1495 if (call->count >= AFSNAMEMAX)
1496 return afs_protocol_error(call, -EBADMSG,
1497 afs_eproto_volname_len);
1498 size = (call->count + 3) & ~3; /* It's padded */
1499 afs_extract_to_buf(call, size);
1500 call->unmarshall++;
1501
1502 /* Fall through - and extract the volume name */
1503 case 3:
1504 _debug("extract volname");
1505 ret = afs_extract_data(call, true);
1506 if (ret < 0)
1507 return ret;
1508
1509 p = call->buffer;
1510 p[call->count] = 0;
1511 _debug("volname '%s'", p);
1512 afs_extract_to_tmp(call);
1513 call->unmarshall++;
1514
1515 /* Fall through - and extract the offline message length */
1516 case 4:
1517 ret = afs_extract_data(call, true);
1518 if (ret < 0)
1519 return ret;
1520
1521 call->count = ntohl(call->tmp);
1522 _debug("offline msg length: %u", call->count);
1523 if (call->count >= AFSNAMEMAX)
1524 return afs_protocol_error(call, -EBADMSG,
1525 afs_eproto_offline_msg_len);
1526 size = (call->count + 3) & ~3; /* It's padded */
1527 afs_extract_to_buf(call, size);
1528 call->unmarshall++;
1529
1530 /* Fall through - and extract the offline message */
1531 case 5:
1532 _debug("extract offline");
1533 ret = afs_extract_data(call, true);
1534 if (ret < 0)
1535 return ret;
1536
1537 p = call->buffer;
1538 p[call->count] = 0;
1539 _debug("offline '%s'", p);
1540
1541 afs_extract_to_tmp(call);
1542 call->unmarshall++;
1543
1544 /* Fall through - and extract the message of the day length */
1545 case 6:
1546 ret = afs_extract_data(call, true);
1547 if (ret < 0)
1548 return ret;
1549
1550 call->count = ntohl(call->tmp);
1551 _debug("motd length: %u", call->count);
1552 if (call->count >= AFSNAMEMAX)
1553 return afs_protocol_error(call, -EBADMSG,
1554 afs_eproto_motd_len);
1555 size = (call->count + 3) & ~3; /* It's padded */
1556 afs_extract_to_buf(call, size);
1557 call->unmarshall++;
1558
1559 /* Fall through - and extract the message of the day */
1560 case 7:
1561 _debug("extract motd");
1562 ret = afs_extract_data(call, false);
1563 if (ret < 0)
1564 return ret;
1565
1566 p = call->buffer;
1567 p[call->count] = 0;
1568 _debug("motd '%s'", p);
1569
1570 call->unmarshall++;
1571
1572 case 8:
1573 break;
1574 }
1575
1576 _leave(" = 0 [done]");
1577 return 0;
1578 }
1579
1580 /*
1581 * FS.GetVolumeStatus operation type
1582 */
1583 static const struct afs_call_type afs_RXFSGetVolumeStatus = {
1584 .name = "FS.GetVolumeStatus",
1585 .op = afs_FS_GetVolumeStatus,
1586 .deliver = afs_deliver_fs_get_volume_status,
1587 .destructor = afs_flat_call_destructor,
1588 };
1589
1590 /*
1591 * fetch the status of a volume
1592 */
1593 int afs_fs_get_volume_status(struct afs_fs_cursor *fc,
1594 struct afs_volume_status *vs)
1595 {
1596 struct afs_vnode *vnode = fc->vnode;
1597 struct afs_call *call;
1598 struct afs_net *net = afs_v2net(vnode);
1599 __be32 *bp;
1600
1601 if (test_bit(AFS_SERVER_FL_IS_YFS, &fc->cbi->server->flags))
1602 return yfs_fs_get_volume_status(fc, vs);
1603
1604 _enter("");
1605
1606 call = afs_alloc_flat_call(net, &afs_RXFSGetVolumeStatus, 2 * 4,
1607 max(12 * 4, AFSOPAQUEMAX + 1));
1608 if (!call)
1609 return -ENOMEM;
1610
1611 call->key = fc->key;
1612 call->out_volstatus = vs;
1613
1614 /* marshall the parameters */
1615 bp = call->request;
1616 bp[0] = htonl(FSGETVOLUMESTATUS);
1617 bp[1] = htonl(vnode->fid.vid);
1618
1619 afs_use_fs_server(call, fc->cbi);
1620 trace_afs_make_fs_call(call, &vnode->fid);
1621 afs_set_fc_call(call, fc);
1622 afs_make_call(&fc->ac, call, GFP_NOFS);
1623 return afs_wait_for_call_to_complete(call, &fc->ac);
1624 }
1625
1626 /*
1627 * deliver reply data to an FS.SetLock, FS.ExtendLock or FS.ReleaseLock
1628 */
1629 static int afs_deliver_fs_xxxx_lock(struct afs_call *call)
1630 {
1631 const __be32 *bp;
1632 int ret;
1633
1634 _enter("{%u}", call->unmarshall);
1635
1636 ret = afs_transfer_reply(call);
1637 if (ret < 0)
1638 return ret;
1639
1640 /* unmarshall the reply once we've received all of it */
1641 bp = call->buffer;
1642 xdr_decode_AFSVolSync(&bp, call->out_volsync);
1643
1644 _leave(" = 0 [done]");
1645 return 0;
1646 }
1647
1648 /*
1649 * FS.SetLock operation type
1650 */
1651 static const struct afs_call_type afs_RXFSSetLock = {
1652 .name = "FS.SetLock",
1653 .op = afs_FS_SetLock,
1654 .deliver = afs_deliver_fs_xxxx_lock,
1655 .done = afs_lock_op_done,
1656 .destructor = afs_flat_call_destructor,
1657 };
1658
1659 /*
1660 * FS.ExtendLock operation type
1661 */
1662 static const struct afs_call_type afs_RXFSExtendLock = {
1663 .name = "FS.ExtendLock",
1664 .op = afs_FS_ExtendLock,
1665 .deliver = afs_deliver_fs_xxxx_lock,
1666 .done = afs_lock_op_done,
1667 .destructor = afs_flat_call_destructor,
1668 };
1669
1670 /*
1671 * FS.ReleaseLock operation type
1672 */
1673 static const struct afs_call_type afs_RXFSReleaseLock = {
1674 .name = "FS.ReleaseLock",
1675 .op = afs_FS_ReleaseLock,
1676 .deliver = afs_deliver_fs_xxxx_lock,
1677 .destructor = afs_flat_call_destructor,
1678 };
1679
1680 /*
1681 * Set a lock on a file
1682 */
1683 int afs_fs_set_lock(struct afs_fs_cursor *fc, afs_lock_type_t type,
1684 struct afs_status_cb *scb)
1685 {
1686 struct afs_vnode *vnode = fc->vnode;
1687 struct afs_call *call;
1688 struct afs_net *net = afs_v2net(vnode);
1689 __be32 *bp;
1690
1691 if (test_bit(AFS_SERVER_FL_IS_YFS, &fc->cbi->server->flags))
1692 return yfs_fs_set_lock(fc, type, scb);
1693
1694 _enter("");
1695
1696 call = afs_alloc_flat_call(net, &afs_RXFSSetLock, 5 * 4, 6 * 4);
1697 if (!call)
1698 return -ENOMEM;
1699
1700 call->key = fc->key;
1701 call->lvnode = vnode;
1702 call->out_scb = scb;
1703
1704 /* marshall the parameters */
1705 bp = call->request;
1706 *bp++ = htonl(FSSETLOCK);
1707 *bp++ = htonl(vnode->fid.vid);
1708 *bp++ = htonl(vnode->fid.vnode);
1709 *bp++ = htonl(vnode->fid.unique);
1710 *bp++ = htonl(type);
1711
1712 afs_use_fs_server(call, fc->cbi);
1713 trace_afs_make_fs_calli(call, &vnode->fid, type);
1714 afs_set_fc_call(call, fc);
1715 afs_make_call(&fc->ac, call, GFP_NOFS);
1716 return afs_wait_for_call_to_complete(call, &fc->ac);
1717 }
1718
1719 /*
1720 * extend a lock on a file
1721 */
1722 int afs_fs_extend_lock(struct afs_fs_cursor *fc, struct afs_status_cb *scb)
1723 {
1724 struct afs_vnode *vnode = fc->vnode;
1725 struct afs_call *call;
1726 struct afs_net *net = afs_v2net(vnode);
1727 __be32 *bp;
1728
1729 if (test_bit(AFS_SERVER_FL_IS_YFS, &fc->cbi->server->flags))
1730 return yfs_fs_extend_lock(fc, scb);
1731
1732 _enter("");
1733
1734 call = afs_alloc_flat_call(net, &afs_RXFSExtendLock, 4 * 4, 6 * 4);
1735 if (!call)
1736 return -ENOMEM;
1737
1738 call->key = fc->key;
1739 call->lvnode = vnode;
1740 call->out_scb = scb;
1741
1742 /* marshall the parameters */
1743 bp = call->request;
1744 *bp++ = htonl(FSEXTENDLOCK);
1745 *bp++ = htonl(vnode->fid.vid);
1746 *bp++ = htonl(vnode->fid.vnode);
1747 *bp++ = htonl(vnode->fid.unique);
1748
1749 afs_use_fs_server(call, fc->cbi);
1750 trace_afs_make_fs_call(call, &vnode->fid);
1751 afs_set_fc_call(call, fc);
1752 afs_make_call(&fc->ac, call, GFP_NOFS);
1753 return afs_wait_for_call_to_complete(call, &fc->ac);
1754 }
1755
1756 /*
1757 * release a lock on a file
1758 */
1759 int afs_fs_release_lock(struct afs_fs_cursor *fc, struct afs_status_cb *scb)
1760 {
1761 struct afs_vnode *vnode = fc->vnode;
1762 struct afs_call *call;
1763 struct afs_net *net = afs_v2net(vnode);
1764 __be32 *bp;
1765
1766 if (test_bit(AFS_SERVER_FL_IS_YFS, &fc->cbi->server->flags))
1767 return yfs_fs_release_lock(fc, scb);
1768
1769 _enter("");
1770
1771 call = afs_alloc_flat_call(net, &afs_RXFSReleaseLock, 4 * 4, 6 * 4);
1772 if (!call)
1773 return -ENOMEM;
1774
1775 call->key = fc->key;
1776 call->lvnode = vnode;
1777 call->out_scb = scb;
1778
1779 /* marshall the parameters */
1780 bp = call->request;
1781 *bp++ = htonl(FSRELEASELOCK);
1782 *bp++ = htonl(vnode->fid.vid);
1783 *bp++ = htonl(vnode->fid.vnode);
1784 *bp++ = htonl(vnode->fid.unique);
1785
1786 afs_use_fs_server(call, fc->cbi);
1787 trace_afs_make_fs_call(call, &vnode->fid);
1788 afs_set_fc_call(call, fc);
1789 afs_make_call(&fc->ac, call, GFP_NOFS);
1790 return afs_wait_for_call_to_complete(call, &fc->ac);
1791 }
1792
1793 /*
1794 * Deliver reply data to an FS.GiveUpAllCallBacks operation.
1795 */
1796 static int afs_deliver_fs_give_up_all_callbacks(struct afs_call *call)
1797 {
1798 return afs_transfer_reply(call);
1799 }
1800
1801 /*
1802 * FS.GiveUpAllCallBacks operation type
1803 */
1804 static const struct afs_call_type afs_RXFSGiveUpAllCallBacks = {
1805 .name = "FS.GiveUpAllCallBacks",
1806 .op = afs_FS_GiveUpAllCallBacks,
1807 .deliver = afs_deliver_fs_give_up_all_callbacks,
1808 .destructor = afs_flat_call_destructor,
1809 };
1810
1811 /*
1812 * Flush all the callbacks we have on a server.
1813 */
1814 int afs_fs_give_up_all_callbacks(struct afs_net *net,
1815 struct afs_server *server,
1816 struct afs_addr_cursor *ac,
1817 struct key *key)
1818 {
1819 struct afs_call *call;
1820 __be32 *bp;
1821
1822 _enter("");
1823
1824 call = afs_alloc_flat_call(net, &afs_RXFSGiveUpAllCallBacks, 1 * 4, 0);
1825 if (!call)
1826 return -ENOMEM;
1827
1828 call->key = key;
1829
1830 /* marshall the parameters */
1831 bp = call->request;
1832 *bp++ = htonl(FSGIVEUPALLCALLBACKS);
1833
1834 /* Can't take a ref on server */
1835 afs_make_call(ac, call, GFP_NOFS);
1836 return afs_wait_for_call_to_complete(call, ac);
1837 }
1838
1839 /*
1840 * Deliver reply data to an FS.GetCapabilities operation.
1841 */
1842 static int afs_deliver_fs_get_capabilities(struct afs_call *call)
1843 {
1844 u32 count;
1845 int ret;
1846
1847 _enter("{%u,%zu}", call->unmarshall, iov_iter_count(&call->iter));
1848
1849 switch (call->unmarshall) {
1850 case 0:
1851 afs_extract_to_tmp(call);
1852 call->unmarshall++;
1853
1854 /* Fall through - and extract the capabilities word count */
1855 case 1:
1856 ret = afs_extract_data(call, true);
1857 if (ret < 0)
1858 return ret;
1859
1860 count = ntohl(call->tmp);
1861
1862 call->count = count;
1863 call->count2 = count;
1864 iov_iter_discard(&call->iter, READ, count * sizeof(__be32));
1865 call->unmarshall++;
1866
1867 /* Fall through - and extract capabilities words */
1868 case 2:
1869 ret = afs_extract_data(call, false);
1870 if (ret < 0)
1871 return ret;
1872
1873 /* TODO: Examine capabilities */
1874
1875 call->unmarshall++;
1876 break;
1877 }
1878
1879 _leave(" = 0 [done]");
1880 return 0;
1881 }
1882
1883 /*
1884 * FS.GetCapabilities operation type
1885 */
1886 static const struct afs_call_type afs_RXFSGetCapabilities = {
1887 .name = "FS.GetCapabilities",
1888 .op = afs_FS_GetCapabilities,
1889 .deliver = afs_deliver_fs_get_capabilities,
1890 .done = afs_fileserver_probe_result,
1891 .destructor = afs_flat_call_destructor,
1892 };
1893
1894 /*
1895 * Probe a fileserver for the capabilities that it supports. This can
1896 * return up to 196 words.
1897 */
1898 struct afs_call *afs_fs_get_capabilities(struct afs_net *net,
1899 struct afs_server *server,
1900 struct afs_addr_cursor *ac,
1901 struct key *key,
1902 unsigned int server_index)
1903 {
1904 struct afs_call *call;
1905 __be32 *bp;
1906
1907 _enter("");
1908
1909 call = afs_alloc_flat_call(net, &afs_RXFSGetCapabilities, 1 * 4, 16 * 4);
1910 if (!call)
1911 return ERR_PTR(-ENOMEM);
1912
1913 call->key = key;
1914 call->server = afs_get_server(server, afs_server_trace_get_caps);
1915 call->server_index = server_index;
1916 call->upgrade = true;
1917 call->async = true;
1918 call->max_lifespan = AFS_PROBE_MAX_LIFESPAN;
1919
1920 /* marshall the parameters */
1921 bp = call->request;
1922 *bp++ = htonl(FSGETCAPABILITIES);
1923
1924 /* Can't take a ref on server */
1925 trace_afs_make_fs_call(call, NULL);
1926 afs_make_call(ac, call, GFP_NOFS);
1927 return call;
1928 }
1929
1930 /*
1931 * Deliver reply data to an FS.FetchStatus with no vnode.
1932 */
1933 static int afs_deliver_fs_fetch_status(struct afs_call *call)
1934 {
1935 const __be32 *bp;
1936 int ret;
1937
1938 ret = afs_transfer_reply(call);
1939 if (ret < 0)
1940 return ret;
1941
1942 /* unmarshall the reply once we've received all of it */
1943 bp = call->buffer;
1944 ret = xdr_decode_AFSFetchStatus(&bp, call, call->out_scb);
1945 if (ret < 0)
1946 return ret;
1947 xdr_decode_AFSCallBack(&bp, call, call->out_scb);
1948 xdr_decode_AFSVolSync(&bp, call->out_volsync);
1949
1950 _leave(" = 0 [done]");
1951 return 0;
1952 }
1953
1954 /*
1955 * FS.FetchStatus operation type
1956 */
1957 static const struct afs_call_type afs_RXFSFetchStatus = {
1958 .name = "FS.FetchStatus",
1959 .op = afs_FS_FetchStatus,
1960 .deliver = afs_deliver_fs_fetch_status,
1961 .destructor = afs_flat_call_destructor,
1962 };
1963
1964 /*
1965 * Fetch the status information for a fid without needing a vnode handle.
1966 */
1967 int afs_fs_fetch_status(struct afs_fs_cursor *fc,
1968 struct afs_net *net,
1969 struct afs_fid *fid,
1970 struct afs_status_cb *scb,
1971 struct afs_volsync *volsync)
1972 {
1973 struct afs_call *call;
1974 __be32 *bp;
1975
1976 if (test_bit(AFS_SERVER_FL_IS_YFS, &fc->cbi->server->flags))
1977 return yfs_fs_fetch_status(fc, net, fid, scb, volsync);
1978
1979 _enter(",%x,{%llx:%llu},,",
1980 key_serial(fc->key), fid->vid, fid->vnode);
1981
1982 call = afs_alloc_flat_call(net, &afs_RXFSFetchStatus, 16, (21 + 3 + 6) * 4);
1983 if (!call) {
1984 fc->ac.error = -ENOMEM;
1985 return -ENOMEM;
1986 }
1987
1988 call->key = fc->key;
1989 call->out_fid = fid;
1990 call->out_scb = scb;
1991 call->out_volsync = volsync;
1992
1993 /* marshall the parameters */
1994 bp = call->request;
1995 bp[0] = htonl(FSFETCHSTATUS);
1996 bp[1] = htonl(fid->vid);
1997 bp[2] = htonl(fid->vnode);
1998 bp[3] = htonl(fid->unique);
1999
2000 afs_use_fs_server(call, fc->cbi);
2001 trace_afs_make_fs_call(call, fid);
2002 afs_set_fc_call(call, fc);
2003 afs_make_call(&fc->ac, call, GFP_NOFS);
2004 return afs_wait_for_call_to_complete(call, &fc->ac);
2005 }
2006
2007 /*
2008 * Deliver reply data to an FS.InlineBulkStatus call
2009 */
2010 static int afs_deliver_fs_inline_bulk_status(struct afs_call *call)
2011 {
2012 struct afs_status_cb *scb;
2013 const __be32 *bp;
2014 u32 tmp;
2015 int ret;
2016
2017 _enter("{%u}", call->unmarshall);
2018
2019 switch (call->unmarshall) {
2020 case 0:
2021 afs_extract_to_tmp(call);
2022 call->unmarshall++;
2023
2024 /* Extract the file status count and array in two steps */
2025 /* Fall through */
2026 case 1:
2027 _debug("extract status count");
2028 ret = afs_extract_data(call, true);
2029 if (ret < 0)
2030 return ret;
2031
2032 tmp = ntohl(call->tmp);
2033 _debug("status count: %u/%u", tmp, call->count2);
2034 if (tmp != call->count2)
2035 return afs_protocol_error(call, -EBADMSG,
2036 afs_eproto_ibulkst_count);
2037
2038 call->count = 0;
2039 call->unmarshall++;
2040 more_counts:
2041 afs_extract_to_buf(call, 21 * sizeof(__be32));
2042
2043 /* Fall through */
2044 case 2:
2045 _debug("extract status array %u", call->count);
2046 ret = afs_extract_data(call, true);
2047 if (ret < 0)
2048 return ret;
2049
2050 bp = call->buffer;
2051 scb = &call->out_scb[call->count];
2052 ret = xdr_decode_AFSFetchStatus(&bp, call, scb);
2053 if (ret < 0)
2054 return ret;
2055
2056 call->count++;
2057 if (call->count < call->count2)
2058 goto more_counts;
2059
2060 call->count = 0;
2061 call->unmarshall++;
2062 afs_extract_to_tmp(call);
2063
2064 /* Extract the callback count and array in two steps */
2065 /* Fall through */
2066 case 3:
2067 _debug("extract CB count");
2068 ret = afs_extract_data(call, true);
2069 if (ret < 0)
2070 return ret;
2071
2072 tmp = ntohl(call->tmp);
2073 _debug("CB count: %u", tmp);
2074 if (tmp != call->count2)
2075 return afs_protocol_error(call, -EBADMSG,
2076 afs_eproto_ibulkst_cb_count);
2077 call->count = 0;
2078 call->unmarshall++;
2079 more_cbs:
2080 afs_extract_to_buf(call, 3 * sizeof(__be32));
2081
2082 /* Fall through */
2083 case 4:
2084 _debug("extract CB array");
2085 ret = afs_extract_data(call, true);
2086 if (ret < 0)
2087 return ret;
2088
2089 _debug("unmarshall CB array");
2090 bp = call->buffer;
2091 scb = &call->out_scb[call->count];
2092 xdr_decode_AFSCallBack(&bp, call, scb);
2093 call->count++;
2094 if (call->count < call->count2)
2095 goto more_cbs;
2096
2097 afs_extract_to_buf(call, 6 * sizeof(__be32));
2098 call->unmarshall++;
2099
2100 /* Fall through */
2101 case 5:
2102 ret = afs_extract_data(call, false);
2103 if (ret < 0)
2104 return ret;
2105
2106 bp = call->buffer;
2107 xdr_decode_AFSVolSync(&bp, call->out_volsync);
2108
2109 call->unmarshall++;
2110
2111 case 6:
2112 break;
2113 }
2114
2115 _leave(" = 0 [done]");
2116 return 0;
2117 }
2118
2119 /*
2120 * FS.InlineBulkStatus operation type
2121 */
2122 static const struct afs_call_type afs_RXFSInlineBulkStatus = {
2123 .name = "FS.InlineBulkStatus",
2124 .op = afs_FS_InlineBulkStatus,
2125 .deliver = afs_deliver_fs_inline_bulk_status,
2126 .destructor = afs_flat_call_destructor,
2127 };
2128
2129 /*
2130 * Fetch the status information for up to 50 files
2131 */
2132 int afs_fs_inline_bulk_status(struct afs_fs_cursor *fc,
2133 struct afs_net *net,
2134 struct afs_fid *fids,
2135 struct afs_status_cb *statuses,
2136 unsigned int nr_fids,
2137 struct afs_volsync *volsync)
2138 {
2139 struct afs_call *call;
2140 __be32 *bp;
2141 int i;
2142
2143 if (test_bit(AFS_SERVER_FL_IS_YFS, &fc->cbi->server->flags))
2144 return yfs_fs_inline_bulk_status(fc, net, fids, statuses,
2145 nr_fids, volsync);
2146
2147 _enter(",%x,{%llx:%llu},%u",
2148 key_serial(fc->key), fids[0].vid, fids[1].vnode, nr_fids);
2149
2150 call = afs_alloc_flat_call(net, &afs_RXFSInlineBulkStatus,
2151 (2 + nr_fids * 3) * 4,
2152 21 * 4);
2153 if (!call) {
2154 fc->ac.error = -ENOMEM;
2155 return -ENOMEM;
2156 }
2157
2158 call->key = fc->key;
2159 call->out_scb = statuses;
2160 call->out_volsync = volsync;
2161 call->count2 = nr_fids;
2162
2163 /* marshall the parameters */
2164 bp = call->request;
2165 *bp++ = htonl(FSINLINEBULKSTATUS);
2166 *bp++ = htonl(nr_fids);
2167 for (i = 0; i < nr_fids; i++) {
2168 *bp++ = htonl(fids[i].vid);
2169 *bp++ = htonl(fids[i].vnode);
2170 *bp++ = htonl(fids[i].unique);
2171 }
2172
2173 afs_use_fs_server(call, fc->cbi);
2174 trace_afs_make_fs_call(call, &fids[0]);
2175 afs_set_fc_call(call, fc);
2176 afs_make_call(&fc->ac, call, GFP_NOFS);
2177 return afs_wait_for_call_to_complete(call, &fc->ac);
2178 }
2179
2180 /*
2181 * deliver reply data to an FS.FetchACL
2182 */
2183 static int afs_deliver_fs_fetch_acl(struct afs_call *call)
2184 {
2185 struct afs_acl *acl;
2186 const __be32 *bp;
2187 unsigned int size;
2188 int ret;
2189
2190 _enter("{%u}", call->unmarshall);
2191
2192 switch (call->unmarshall) {
2193 case 0:
2194 afs_extract_to_tmp(call);
2195 call->unmarshall++;
2196
2197 /* extract the returned data length */
2198 case 1:
2199 ret = afs_extract_data(call, true);
2200 if (ret < 0)
2201 return ret;
2202
2203 size = call->count2 = ntohl(call->tmp);
2204 size = round_up(size, 4);
2205
2206 acl = kmalloc(struct_size(acl, data, size), GFP_KERNEL);
2207 if (!acl)
2208 return -ENOMEM;
2209 call->ret_acl = acl;
2210 acl->size = call->count2;
2211 afs_extract_begin(call, acl->data, size);
2212 call->unmarshall++;
2213
2214 /* extract the returned data */
2215 case 2:
2216 ret = afs_extract_data(call, true);
2217 if (ret < 0)
2218 return ret;
2219
2220 afs_extract_to_buf(call, (21 + 6) * 4);
2221 call->unmarshall++;
2222
2223 /* extract the metadata */
2224 case 3:
2225 ret = afs_extract_data(call, false);
2226 if (ret < 0)
2227 return ret;
2228
2229 bp = call->buffer;
2230 ret = xdr_decode_AFSFetchStatus(&bp, call, call->out_scb);
2231 if (ret < 0)
2232 return ret;
2233 xdr_decode_AFSVolSync(&bp, call->out_volsync);
2234
2235 call->unmarshall++;
2236
2237 case 4:
2238 break;
2239 }
2240
2241 _leave(" = 0 [done]");
2242 return 0;
2243 }
2244
2245 static void afs_destroy_fs_fetch_acl(struct afs_call *call)
2246 {
2247 kfree(call->ret_acl);
2248 afs_flat_call_destructor(call);
2249 }
2250
2251 /*
2252 * FS.FetchACL operation type
2253 */
2254 static const struct afs_call_type afs_RXFSFetchACL = {
2255 .name = "FS.FetchACL",
2256 .op = afs_FS_FetchACL,
2257 .deliver = afs_deliver_fs_fetch_acl,
2258 .destructor = afs_destroy_fs_fetch_acl,
2259 };
2260
2261 /*
2262 * Fetch the ACL for a file.
2263 */
2264 struct afs_acl *afs_fs_fetch_acl(struct afs_fs_cursor *fc,
2265 struct afs_status_cb *scb)
2266 {
2267 struct afs_vnode *vnode = fc->vnode;
2268 struct afs_call *call;
2269 struct afs_net *net = afs_v2net(vnode);
2270 __be32 *bp;
2271
2272 _enter(",%x,{%llx:%llu},,",
2273 key_serial(fc->key), vnode->fid.vid, vnode->fid.vnode);
2274
2275 call = afs_alloc_flat_call(net, &afs_RXFSFetchACL, 16, (21 + 6) * 4);
2276 if (!call) {
2277 fc->ac.error = -ENOMEM;
2278 return ERR_PTR(-ENOMEM);
2279 }
2280
2281 call->key = fc->key;
2282 call->ret_acl = NULL;
2283 call->out_scb = scb;
2284 call->out_volsync = NULL;
2285
2286 /* marshall the parameters */
2287 bp = call->request;
2288 bp[0] = htonl(FSFETCHACL);
2289 bp[1] = htonl(vnode->fid.vid);
2290 bp[2] = htonl(vnode->fid.vnode);
2291 bp[3] = htonl(vnode->fid.unique);
2292
2293 afs_use_fs_server(call, fc->cbi);
2294 trace_afs_make_fs_call(call, &vnode->fid);
2295 afs_make_call(&fc->ac, call, GFP_KERNEL);
2296 return (struct afs_acl *)afs_wait_for_call_to_complete(call, &fc->ac);
2297 }
2298
2299 /*
2300 * Deliver reply data to any operation that returns file status and volume
2301 * sync.
2302 */
2303 static int afs_deliver_fs_file_status_and_vol(struct afs_call *call)
2304 {
2305 const __be32 *bp;
2306 int ret;
2307
2308 ret = afs_transfer_reply(call);
2309 if (ret < 0)
2310 return ret;
2311
2312 bp = call->buffer;
2313 ret = xdr_decode_AFSFetchStatus(&bp, call, call->out_scb);
2314 if (ret < 0)
2315 return ret;
2316 xdr_decode_AFSVolSync(&bp, call->out_volsync);
2317
2318 _leave(" = 0 [done]");
2319 return 0;
2320 }
2321
2322 /*
2323 * FS.StoreACL operation type
2324 */
2325 static const struct afs_call_type afs_RXFSStoreACL = {
2326 .name = "FS.StoreACL",
2327 .op = afs_FS_StoreACL,
2328 .deliver = afs_deliver_fs_file_status_and_vol,
2329 .destructor = afs_flat_call_destructor,
2330 };
2331
2332 /*
2333 * Fetch the ACL for a file.
2334 */
2335 int afs_fs_store_acl(struct afs_fs_cursor *fc, const struct afs_acl *acl,
2336 struct afs_status_cb *scb)
2337 {
2338 struct afs_vnode *vnode = fc->vnode;
2339 struct afs_call *call;
2340 struct afs_net *net = afs_v2net(vnode);
2341 size_t size;
2342 __be32 *bp;
2343
2344 _enter(",%x,{%llx:%llu},,",
2345 key_serial(fc->key), vnode->fid.vid, vnode->fid.vnode);
2346
2347 size = round_up(acl->size, 4);
2348 call = afs_alloc_flat_call(net, &afs_RXFSStoreACL,
2349 5 * 4 + size, (21 + 6) * 4);
2350 if (!call) {
2351 fc->ac.error = -ENOMEM;
2352 return -ENOMEM;
2353 }
2354
2355 call->key = fc->key;
2356 call->out_scb = scb;
2357 call->out_volsync = NULL;
2358
2359 /* marshall the parameters */
2360 bp = call->request;
2361 bp[0] = htonl(FSSTOREACL);
2362 bp[1] = htonl(vnode->fid.vid);
2363 bp[2] = htonl(vnode->fid.vnode);
2364 bp[3] = htonl(vnode->fid.unique);
2365 bp[4] = htonl(acl->size);
2366 memcpy(&bp[5], acl->data, acl->size);
2367 if (acl->size != size)
2368 memset((void *)&bp[5] + acl->size, 0, size - acl->size);
2369
2370 trace_afs_make_fs_call(call, &vnode->fid);
2371 afs_make_call(&fc->ac, call, GFP_KERNEL);
2372 return afs_wait_for_call_to_complete(call, &fc->ac);
2373 }
A mirror of Linus' kernel repository