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