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); 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 } 2374