?  search:
summary | log | graphiclog1 | graphiclog2 | commit | commitdiff | tree | refs | edit | fork
blame | history | raw | HEAD
mm: fix exec activate_mm vs TLB shootdown and lazy tlb switching race
[linux/fpc-iii.git] / fs / afs / fsclient.c
blob19f76ae36982df43be740c1bf73d396b1a81c77c
1 /* AFS File Server client stubs
2 *
3 * Copyright (C) 2002, 2007 Red Hat, Inc. All Rights Reserved.
4 * Written by David Howells (dhowells@redhat.com)
5 *
6 * This program is free software; you can redistribute it and/or
7 * modify it under the terms of the GNU General Public License
8 * as published by the Free Software Foundation; either version
9 * 2 of the License, or (at your option) any later version.
10 */
11
12 #include <linux/init.h>
13 #include <linux/slab.h>
14 #include <linux/sched.h>
15 #include <linux/circ_buf.h>
16 #include "internal.h"
17 #include "afs_fs.h"
18
19 /*
20 * We need somewhere to discard into in case the server helpfully returns more
21 * than we asked for in FS.FetchData{,64}.
22 */
23 static u8 afs_discard_buffer[64];
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 * decode an AFSFetchStatus block
40 */
41 static void xdr_decode_AFSFetchStatus(const __be32 **_bp,
42 struct afs_file_status *status,
43 struct afs_vnode *vnode,
44 afs_dataversion_t *store_version)
45 {
46 afs_dataversion_t expected_version;
47 const __be32 *bp = *_bp;
48 umode_t mode;
49 u64 data_version, size;
50 u32 changed = 0; /* becomes non-zero if ctime-type changes seen */
51 kuid_t owner;
52 kgid_t group;
53
54 #define EXTRACT(DST) \
55 do { \
56 u32 x = ntohl(*bp++); \
57 changed |= DST - x; \
58 DST = x; \
59 } while (0)
60
61 status->if_version = ntohl(*bp++);
62 EXTRACT(status->type);
63 EXTRACT(status->nlink);
64 size = ntohl(*bp++);
65 data_version = ntohl(*bp++);
66 EXTRACT(status->author);
67 owner = make_kuid(&init_user_ns, ntohl(*bp++));
68 changed |= !uid_eq(owner, status->owner);
69 status->owner = owner;
70 EXTRACT(status->caller_access); /* call ticket dependent */
71 EXTRACT(status->anon_access);
72 EXTRACT(status->mode);
73 EXTRACT(status->parent.vnode);
74 EXTRACT(status->parent.unique);
75 bp++; /* seg size */
76 status->mtime_client = ntohl(*bp++);
77 status->mtime_server = ntohl(*bp++);
78 group = make_kgid(&init_user_ns, ntohl(*bp++));
79 changed |= !gid_eq(group, status->group);
80 status->group = group;
81 bp++; /* sync counter */
82 data_version |= (u64) ntohl(*bp++) << 32;
83 EXTRACT(status->lock_count);
84 size |= (u64) ntohl(*bp++) << 32;
85 bp++; /* spare 4 */
86 *_bp = bp;
87
88 if (size != status->size) {
89 status->size = size;
90 changed |= true;
91 }
92 status->mode &= S_IALLUGO;
93
94 _debug("vnode time %lx, %lx",
95 status->mtime_client, status->mtime_server);
96
97 if (vnode) {
98 status->parent.vid = vnode->fid.vid;
99 if (changed && !test_bit(AFS_VNODE_UNSET, &vnode->flags)) {
100 _debug("vnode changed");
101 i_size_write(&vnode->vfs_inode, size);
102 vnode->vfs_inode.i_uid = status->owner;
103 vnode->vfs_inode.i_gid = status->group;
104 vnode->vfs_inode.i_generation = vnode->fid.unique;
105 set_nlink(&vnode->vfs_inode, status->nlink);
106
107 mode = vnode->vfs_inode.i_mode;
108 mode &= ~S_IALLUGO;
109 mode |= status->mode;
110 barrier();
111 vnode->vfs_inode.i_mode = mode;
112 }
113
114 vnode->vfs_inode.i_ctime.tv_sec = status->mtime_client;
115 vnode->vfs_inode.i_mtime = vnode->vfs_inode.i_ctime;
116 vnode->vfs_inode.i_atime = vnode->vfs_inode.i_ctime;
117 vnode->vfs_inode.i_version = data_version;
118 }
119
120 expected_version = status->data_version;
121 if (store_version)
122 expected_version = *store_version;
123
124 if (expected_version != data_version) {
125 status->data_version = data_version;
126 if (vnode && !test_bit(AFS_VNODE_UNSET, &vnode->flags)) {
127 _debug("vnode modified %llx on {%x:%u}",
128 (unsigned long long) data_version,
129 vnode->fid.vid, vnode->fid.vnode);
130 set_bit(AFS_VNODE_MODIFIED, &vnode->flags);
131 set_bit(AFS_VNODE_ZAP_DATA, &vnode->flags);
132 }
133 } else if (store_version) {
134 status->data_version = data_version;
135 }
136 }
137
138 /*
139 * decode an AFSCallBack block
140 */
141 static void xdr_decode_AFSCallBack(const __be32 **_bp, struct afs_vnode *vnode)
142 {
143 const __be32 *bp = *_bp;
144
145 vnode->cb_version = ntohl(*bp++);
146 vnode->cb_expiry = ntohl(*bp++);
147 vnode->cb_type = ntohl(*bp++);
148 vnode->cb_expires = vnode->cb_expiry + ktime_get_real_seconds();
149 *_bp = bp;
150 }
151
152 static void xdr_decode_AFSCallBack_raw(const __be32 **_bp,
153 struct afs_callback *cb)
154 {
155 const __be32 *bp = *_bp;
156
157 cb->version = ntohl(*bp++);
158 cb->expiry = ntohl(*bp++);
159 cb->type = ntohl(*bp++);
160 *_bp = bp;
161 }
162
163 /*
164 * decode an AFSVolSync block
165 */
166 static void xdr_decode_AFSVolSync(const __be32 **_bp,
167 struct afs_volsync *volsync)
168 {
169 const __be32 *bp = *_bp;
170
171 volsync->creation = ntohl(*bp++);
172 bp++; /* spare2 */
173 bp++; /* spare3 */
174 bp++; /* spare4 */
175 bp++; /* spare5 */
176 bp++; /* spare6 */
177 *_bp = bp;
178 }
179
180 /*
181 * encode the requested attributes into an AFSStoreStatus block
182 */
183 static void xdr_encode_AFS_StoreStatus(__be32 **_bp, struct iattr *attr)
184 {
185 __be32 *bp = *_bp;
186 u32 mask = 0, mtime = 0, owner = 0, group = 0, mode = 0;
187
188 mask = 0;
189 if (attr->ia_valid & ATTR_MTIME) {
190 mask |= AFS_SET_MTIME;
191 mtime = attr->ia_mtime.tv_sec;
192 }
193
194 if (attr->ia_valid & ATTR_UID) {
195 mask |= AFS_SET_OWNER;
196 owner = from_kuid(&init_user_ns, attr->ia_uid);
197 }
198
199 if (attr->ia_valid & ATTR_GID) {
200 mask |= AFS_SET_GROUP;
201 group = from_kgid(&init_user_ns, attr->ia_gid);
202 }
203
204 if (attr->ia_valid & ATTR_MODE) {
205 mask |= AFS_SET_MODE;
206 mode = attr->ia_mode & S_IALLUGO;
207 }
208
209 *bp++ = htonl(mask);
210 *bp++ = htonl(mtime);
211 *bp++ = htonl(owner);
212 *bp++ = htonl(group);
213 *bp++ = htonl(mode);
214 *bp++ = 0; /* segment size */
215 *_bp = bp;
216 }
217
218 /*
219 * decode an AFSFetchVolumeStatus block
220 */
221 static void xdr_decode_AFSFetchVolumeStatus(const __be32 **_bp,
222 struct afs_volume_status *vs)
223 {
224 const __be32 *bp = *_bp;
225
226 vs->vid = ntohl(*bp++);
227 vs->parent_id = ntohl(*bp++);
228 vs->online = ntohl(*bp++);
229 vs->in_service = ntohl(*bp++);
230 vs->blessed = ntohl(*bp++);
231 vs->needs_salvage = ntohl(*bp++);
232 vs->type = ntohl(*bp++);
233 vs->min_quota = ntohl(*bp++);
234 vs->max_quota = ntohl(*bp++);
235 vs->blocks_in_use = ntohl(*bp++);
236 vs->part_blocks_avail = ntohl(*bp++);
237 vs->part_max_blocks = ntohl(*bp++);
238 *_bp = bp;
239 }
240
241 /*
242 * deliver reply data to an FS.FetchStatus
243 */
244 static int afs_deliver_fs_fetch_status(struct afs_call *call)
245 {
246 struct afs_vnode *vnode = call->reply;
247 const __be32 *bp;
248 int ret;
249
250 _enter("");
251
252 ret = afs_transfer_reply(call);
253 if (ret < 0)
254 return ret;
255
256 /* unmarshall the reply once we've received all of it */
257 bp = call->buffer;
258 xdr_decode_AFSFetchStatus(&bp, &vnode->status, vnode, NULL);
259 xdr_decode_AFSCallBack(&bp, vnode);
260 if (call->reply2)
261 xdr_decode_AFSVolSync(&bp, call->reply2);
262
263 _leave(" = 0 [done]");
264 return 0;
265 }
266
267 /*
268 * FS.FetchStatus operation type
269 */
270 static const struct afs_call_type afs_RXFSFetchStatus = {
271 .name = "FS.FetchStatus",
272 .deliver = afs_deliver_fs_fetch_status,
273 .abort_to_error = afs_abort_to_error,
274 .destructor = afs_flat_call_destructor,
275 };
276
277 /*
278 * fetch the status information for a file
279 */
280 int afs_fs_fetch_file_status(struct afs_server *server,
281 struct key *key,
282 struct afs_vnode *vnode,
283 struct afs_volsync *volsync,
284 bool async)
285 {
286 struct afs_call *call;
287 __be32 *bp;
288
289 _enter(",%x,{%x:%u},,",
290 key_serial(key), vnode->fid.vid, vnode->fid.vnode);
291
292 call = afs_alloc_flat_call(&afs_RXFSFetchStatus, 16, (21 + 3 + 6) * 4);
293 if (!call)
294 return -ENOMEM;
295
296 call->key = key;
297 call->reply = vnode;
298 call->reply2 = volsync;
299 call->service_id = FS_SERVICE;
300 call->port = htons(AFS_FS_PORT);
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 return afs_make_call(&server->addr, call, GFP_NOFS, async);
310 }
311
312 /*
313 * deliver reply data to an FS.FetchData
314 */
315 static int afs_deliver_fs_fetch_data(struct afs_call *call)
316 {
317 struct afs_vnode *vnode = call->reply;
318 struct afs_read *req = call->reply3;
319 const __be32 *bp;
320 unsigned int size;
321 void *buffer;
322 int ret;
323
324 _enter("{%u,%zu/%u;%llu/%llu}",
325 call->unmarshall, call->offset, call->count,
326 req->remain, req->actual_len);
327
328 switch (call->unmarshall) {
329 case 0:
330 req->actual_len = 0;
331 call->offset = 0;
332 call->unmarshall++;
333 if (call->operation_ID != FSFETCHDATA64) {
334 call->unmarshall++;
335 goto no_msw;
336 }
337
338 /* extract the upper part of the returned data length of an
339 * FSFETCHDATA64 op (which should always be 0 using this
340 * client) */
341 case 1:
342 _debug("extract data length (MSW)");
343 ret = afs_extract_data(call, &call->tmp, 4, true);
344 if (ret < 0)
345 return ret;
346
347 req->actual_len = ntohl(call->tmp);
348 req->actual_len <<= 32;
349 call->offset = 0;
350 call->unmarshall++;
351
352 no_msw:
353 /* extract the returned data length */
354 case 2:
355 _debug("extract data length");
356 ret = afs_extract_data(call, &call->tmp, 4, true);
357 if (ret < 0)
358 return ret;
359
360 req->actual_len |= ntohl(call->tmp);
361 _debug("DATA length: %llu", req->actual_len);
362
363 req->remain = req->actual_len;
364 call->offset = req->pos & (PAGE_SIZE - 1);
365 req->index = 0;
366 if (req->actual_len == 0)
367 goto no_more_data;
368 call->unmarshall++;
369
370 begin_page:
371 ASSERTCMP(req->index, <, req->nr_pages);
372 if (req->remain > PAGE_SIZE - call->offset)
373 size = PAGE_SIZE - call->offset;
374 else
375 size = req->remain;
376 call->count = call->offset + size;
377 ASSERTCMP(call->count, <=, PAGE_SIZE);
378 req->remain -= size;
379
380 /* extract the returned data */
381 case 3:
382 _debug("extract data %llu/%llu %zu/%u",
383 req->remain, req->actual_len, call->offset, call->count);
384
385 buffer = kmap(req->pages[req->index]);
386 ret = afs_extract_data(call, buffer, call->count, true);
387 kunmap(req->pages[req->index]);
388 if (ret < 0)
389 return ret;
390 if (call->offset == PAGE_SIZE) {
391 if (req->page_done)
392 req->page_done(call, req);
393 req->index++;
394 if (req->remain > 0) {
395 call->offset = 0;
396 if (req->index >= req->nr_pages) {
397 call->unmarshall = 4;
398 goto begin_discard;
399 }
400 goto begin_page;
401 }
402 }
403 goto no_more_data;
404
405 /* Discard any excess data the server gave us */
406 begin_discard:
407 case 4:
408 size = min_t(loff_t, sizeof(afs_discard_buffer), req->remain);
409 call->count = size;
410 _debug("extract discard %llu/%llu %zu/%u",
411 req->remain, req->actual_len, call->offset, call->count);
412
413 call->offset = 0;
414 ret = afs_extract_data(call, afs_discard_buffer, call->count, true);
415 req->remain -= call->offset;
416 if (ret < 0)
417 return ret;
418 if (req->remain > 0)
419 goto begin_discard;
420
421 no_more_data:
422 call->offset = 0;
423 call->unmarshall = 5;
424
425 /* extract the metadata */
426 case 5:
427 ret = afs_extract_data(call, call->buffer,
428 (21 + 3 + 6) * 4, false);
429 if (ret < 0)
430 return ret;
431
432 bp = call->buffer;
433 xdr_decode_AFSFetchStatus(&bp, &vnode->status, vnode, NULL);
434 xdr_decode_AFSCallBack(&bp, vnode);
435 if (call->reply2)
436 xdr_decode_AFSVolSync(&bp, call->reply2);
437
438 call->offset = 0;
439 call->unmarshall++;
440
441 case 6:
442 break;
443 }
444
445 for (; req->index < req->nr_pages; req->index++) {
446 if (call->count < PAGE_SIZE)
447 zero_user_segment(req->pages[req->index],
448 call->count, PAGE_SIZE);
449 if (req->page_done)
450 req->page_done(call, req);
451 call->count = 0;
452 }
453
454 _leave(" = 0 [done]");
455 return 0;
456 }
457
458 static void afs_fetch_data_destructor(struct afs_call *call)
459 {
460 struct afs_read *req = call->reply3;
461
462 afs_put_read(req);
463 afs_flat_call_destructor(call);
464 }
465
466 /*
467 * FS.FetchData operation type
468 */
469 static const struct afs_call_type afs_RXFSFetchData = {
470 .name = "FS.FetchData",
471 .deliver = afs_deliver_fs_fetch_data,
472 .abort_to_error = afs_abort_to_error,
473 .destructor = afs_fetch_data_destructor,
474 };
475
476 static const struct afs_call_type afs_RXFSFetchData64 = {
477 .name = "FS.FetchData64",
478 .deliver = afs_deliver_fs_fetch_data,
479 .abort_to_error = afs_abort_to_error,
480 .destructor = afs_fetch_data_destructor,
481 };
482
483 /*
484 * fetch data from a very large file
485 */
486 static int afs_fs_fetch_data64(struct afs_server *server,
487 struct key *key,
488 struct afs_vnode *vnode,
489 struct afs_read *req,
490 bool async)
491 {
492 struct afs_call *call;
493 __be32 *bp;
494
495 _enter("");
496
497 call = afs_alloc_flat_call(&afs_RXFSFetchData64, 32, (21 + 3 + 6) * 4);
498 if (!call)
499 return -ENOMEM;
500
501 call->key = key;
502 call->reply = vnode;
503 call->reply2 = NULL; /* volsync */
504 call->reply3 = req;
505 call->service_id = FS_SERVICE;
506 call->port = htons(AFS_FS_PORT);
507 call->operation_ID = FSFETCHDATA64;
508
509 /* marshall the parameters */
510 bp = call->request;
511 bp[0] = htonl(FSFETCHDATA64);
512 bp[1] = htonl(vnode->fid.vid);
513 bp[2] = htonl(vnode->fid.vnode);
514 bp[3] = htonl(vnode->fid.unique);
515 bp[4] = htonl(upper_32_bits(req->pos));
516 bp[5] = htonl(lower_32_bits(req->pos));
517 bp[6] = 0;
518 bp[7] = htonl(lower_32_bits(req->len));
519
520 atomic_inc(&req->usage);
521 return afs_make_call(&server->addr, call, GFP_NOFS, async);
522 }
523
524 /*
525 * fetch data from a file
526 */
527 int afs_fs_fetch_data(struct afs_server *server,
528 struct key *key,
529 struct afs_vnode *vnode,
530 struct afs_read *req,
531 bool async)
532 {
533 struct afs_call *call;
534 __be32 *bp;
535
536 if (upper_32_bits(req->pos) ||
537 upper_32_bits(req->len) ||
538 upper_32_bits(req->pos + req->len))
539 return afs_fs_fetch_data64(server, key, vnode, req, async);
540
541 _enter("");
542
543 call = afs_alloc_flat_call(&afs_RXFSFetchData, 24, (21 + 3 + 6) * 4);
544 if (!call)
545 return -ENOMEM;
546
547 call->key = key;
548 call->reply = vnode;
549 call->reply2 = NULL; /* volsync */
550 call->reply3 = req;
551 call->service_id = FS_SERVICE;
552 call->port = htons(AFS_FS_PORT);
553 call->operation_ID = FSFETCHDATA;
554
555 /* marshall the parameters */
556 bp = call->request;
557 bp[0] = htonl(FSFETCHDATA);
558 bp[1] = htonl(vnode->fid.vid);
559 bp[2] = htonl(vnode->fid.vnode);
560 bp[3] = htonl(vnode->fid.unique);
561 bp[4] = htonl(lower_32_bits(req->pos));
562 bp[5] = htonl(lower_32_bits(req->len));
563
564 atomic_inc(&req->usage);
565 return afs_make_call(&server->addr, call, GFP_NOFS, async);
566 }
567
568 /*
569 * deliver reply data to an FS.GiveUpCallBacks
570 */
571 static int afs_deliver_fs_give_up_callbacks(struct afs_call *call)
572 {
573 _enter("");
574
575 /* shouldn't be any reply data */
576 return afs_extract_data(call, NULL, 0, false);
577 }
578
579 /*
580 * FS.GiveUpCallBacks operation type
581 */
582 static const struct afs_call_type afs_RXFSGiveUpCallBacks = {
583 .name = "FS.GiveUpCallBacks",
584 .deliver = afs_deliver_fs_give_up_callbacks,
585 .abort_to_error = afs_abort_to_error,
586 .destructor = afs_flat_call_destructor,
587 };
588
589 /*
590 * give up a set of callbacks
591 * - the callbacks are held in the server->cb_break ring
592 */
593 int afs_fs_give_up_callbacks(struct afs_server *server,
594 bool async)
595 {
596 struct afs_call *call;
597 size_t ncallbacks;
598 __be32 *bp, *tp;
599 int loop;
600
601 ncallbacks = CIRC_CNT(server->cb_break_head, server->cb_break_tail,
602 ARRAY_SIZE(server->cb_break));
603
604 _enter("{%zu},", ncallbacks);
605
606 if (ncallbacks == 0)
607 return 0;
608 if (ncallbacks > AFSCBMAX)
609 ncallbacks = AFSCBMAX;
610
611 _debug("break %zu callbacks", ncallbacks);
612
613 call = afs_alloc_flat_call(&afs_RXFSGiveUpCallBacks,
614 12 + ncallbacks * 6 * 4, 0);
615 if (!call)
616 return -ENOMEM;
617
618 call->service_id = FS_SERVICE;
619 call->port = htons(AFS_FS_PORT);
620
621 /* marshall the parameters */
622 bp = call->request;
623 tp = bp + 2 + ncallbacks * 3;
624 *bp++ = htonl(FSGIVEUPCALLBACKS);
625 *bp++ = htonl(ncallbacks);
626 *tp++ = htonl(ncallbacks);
627
628 atomic_sub(ncallbacks, &server->cb_break_n);
629 for (loop = ncallbacks; loop > 0; loop--) {
630 struct afs_callback *cb =
631 &server->cb_break[server->cb_break_tail];
632
633 *bp++ = htonl(cb->fid.vid);
634 *bp++ = htonl(cb->fid.vnode);
635 *bp++ = htonl(cb->fid.unique);
636 *tp++ = htonl(cb->version);
637 *tp++ = htonl(cb->expiry);
638 *tp++ = htonl(cb->type);
639 smp_mb();
640 server->cb_break_tail =
641 (server->cb_break_tail + 1) &
642 (ARRAY_SIZE(server->cb_break) - 1);
643 }
644
645 ASSERT(ncallbacks > 0);
646 wake_up_nr(&server->cb_break_waitq, ncallbacks);
647
648 return afs_make_call(&server->addr, call, GFP_NOFS, async);
649 }
650
651 /*
652 * deliver reply data to an FS.CreateFile or an FS.MakeDir
653 */
654 static int afs_deliver_fs_create_vnode(struct afs_call *call)
655 {
656 struct afs_vnode *vnode = call->reply;
657 const __be32 *bp;
658 int ret;
659
660 _enter("{%u}", call->unmarshall);
661
662 ret = afs_transfer_reply(call);
663 if (ret < 0)
664 return ret;
665
666 /* unmarshall the reply once we've received all of it */
667 bp = call->buffer;
668 xdr_decode_AFSFid(&bp, call->reply2);
669 xdr_decode_AFSFetchStatus(&bp, call->reply3, NULL, NULL);
670 xdr_decode_AFSFetchStatus(&bp, &vnode->status, vnode, NULL);
671 xdr_decode_AFSCallBack_raw(&bp, call->reply4);
672 /* xdr_decode_AFSVolSync(&bp, call->replyX); */
673
674 _leave(" = 0 [done]");
675 return 0;
676 }
677
678 /*
679 * FS.CreateFile and FS.MakeDir operation type
680 */
681 static const struct afs_call_type afs_RXFSCreateXXXX = {
682 .name = "FS.CreateXXXX",
683 .deliver = afs_deliver_fs_create_vnode,
684 .abort_to_error = afs_abort_to_error,
685 .destructor = afs_flat_call_destructor,
686 };
687
688 /*
689 * create a file or make a directory
690 */
691 int afs_fs_create(struct afs_server *server,
692 struct key *key,
693 struct afs_vnode *vnode,
694 const char *name,
695 umode_t mode,
696 struct afs_fid *newfid,
697 struct afs_file_status *newstatus,
698 struct afs_callback *newcb,
699 bool async)
700 {
701 struct afs_call *call;
702 size_t namesz, reqsz, padsz;
703 __be32 *bp;
704
705 _enter("");
706
707 namesz = strlen(name);
708 padsz = (4 - (namesz & 3)) & 3;
709 reqsz = (5 * 4) + namesz + padsz + (6 * 4);
710
711 call = afs_alloc_flat_call(&afs_RXFSCreateXXXX, reqsz,
712 (3 + 21 + 21 + 3 + 6) * 4);
713 if (!call)
714 return -ENOMEM;
715
716 call->key = key;
717 call->reply = vnode;
718 call->reply2 = newfid;
719 call->reply3 = newstatus;
720 call->reply4 = newcb;
721 call->service_id = FS_SERVICE;
722 call->port = htons(AFS_FS_PORT);
723
724 /* marshall the parameters */
725 bp = call->request;
726 *bp++ = htonl(S_ISDIR(mode) ? FSMAKEDIR : FSCREATEFILE);
727 *bp++ = htonl(vnode->fid.vid);
728 *bp++ = htonl(vnode->fid.vnode);
729 *bp++ = htonl(vnode->fid.unique);
730 *bp++ = htonl(namesz);
731 memcpy(bp, name, namesz);
732 bp = (void *) bp + namesz;
733 if (padsz > 0) {
734 memset(bp, 0, padsz);
735 bp = (void *) bp + padsz;
736 }
737 *bp++ = htonl(AFS_SET_MODE | AFS_SET_MTIME);
738 *bp++ = htonl(vnode->vfs_inode.i_mtime.tv_sec); /* mtime */
739 *bp++ = 0; /* owner */
740 *bp++ = 0; /* group */
741 *bp++ = htonl(mode & S_IALLUGO); /* unix mode */
742 *bp++ = 0; /* segment size */
743
744 return afs_make_call(&server->addr, call, GFP_NOFS, async);
745 }
746
747 /*
748 * deliver reply data to an FS.RemoveFile or FS.RemoveDir
749 */
750 static int afs_deliver_fs_remove(struct afs_call *call)
751 {
752 struct afs_vnode *vnode = call->reply;
753 const __be32 *bp;
754 int ret;
755
756 _enter("{%u}", call->unmarshall);
757
758 ret = afs_transfer_reply(call);
759 if (ret < 0)
760 return ret;
761
762 /* unmarshall the reply once we've received all of it */
763 bp = call->buffer;
764 xdr_decode_AFSFetchStatus(&bp, &vnode->status, vnode, NULL);
765 /* xdr_decode_AFSVolSync(&bp, call->replyX); */
766
767 _leave(" = 0 [done]");
768 return 0;
769 }
770
771 /*
772 * FS.RemoveDir/FS.RemoveFile operation type
773 */
774 static const struct afs_call_type afs_RXFSRemoveXXXX = {
775 .name = "FS.RemoveXXXX",
776 .deliver = afs_deliver_fs_remove,
777 .abort_to_error = afs_abort_to_error,
778 .destructor = afs_flat_call_destructor,
779 };
780
781 /*
782 * remove a file or directory
783 */
784 int afs_fs_remove(struct afs_server *server,
785 struct key *key,
786 struct afs_vnode *vnode,
787 const char *name,
788 bool isdir,
789 bool async)
790 {
791 struct afs_call *call;
792 size_t namesz, reqsz, padsz;
793 __be32 *bp;
794
795 _enter("");
796
797 namesz = strlen(name);
798 padsz = (4 - (namesz & 3)) & 3;
799 reqsz = (5 * 4) + namesz + padsz;
800
801 call = afs_alloc_flat_call(&afs_RXFSRemoveXXXX, reqsz, (21 + 6) * 4);
802 if (!call)
803 return -ENOMEM;
804
805 call->key = key;
806 call->reply = vnode;
807 call->service_id = FS_SERVICE;
808 call->port = htons(AFS_FS_PORT);
809
810 /* marshall the parameters */
811 bp = call->request;
812 *bp++ = htonl(isdir ? FSREMOVEDIR : FSREMOVEFILE);
813 *bp++ = htonl(vnode->fid.vid);
814 *bp++ = htonl(vnode->fid.vnode);
815 *bp++ = htonl(vnode->fid.unique);
816 *bp++ = htonl(namesz);
817 memcpy(bp, name, namesz);
818 bp = (void *) bp + namesz;
819 if (padsz > 0) {
820 memset(bp, 0, padsz);
821 bp = (void *) bp + padsz;
822 }
823
824 return afs_make_call(&server->addr, call, GFP_NOFS, async);
825 }
826
827 /*
828 * deliver reply data to an FS.Link
829 */
830 static int afs_deliver_fs_link(struct afs_call *call)
831 {
832 struct afs_vnode *dvnode = call->reply, *vnode = call->reply2;
833 const __be32 *bp;
834 int ret;
835
836 _enter("{%u}", call->unmarshall);
837
838 ret = afs_transfer_reply(call);
839 if (ret < 0)
840 return ret;
841
842 /* unmarshall the reply once we've received all of it */
843 bp = call->buffer;
844 xdr_decode_AFSFetchStatus(&bp, &vnode->status, vnode, NULL);
845 xdr_decode_AFSFetchStatus(&bp, &dvnode->status, dvnode, NULL);
846 /* xdr_decode_AFSVolSync(&bp, call->replyX); */
847
848 _leave(" = 0 [done]");
849 return 0;
850 }
851
852 /*
853 * FS.Link operation type
854 */
855 static const struct afs_call_type afs_RXFSLink = {
856 .name = "FS.Link",
857 .deliver = afs_deliver_fs_link,
858 .abort_to_error = afs_abort_to_error,
859 .destructor = afs_flat_call_destructor,
860 };
861
862 /*
863 * make a hard link
864 */
865 int afs_fs_link(struct afs_server *server,
866 struct key *key,
867 struct afs_vnode *dvnode,
868 struct afs_vnode *vnode,
869 const char *name,
870 bool async)
871 {
872 struct afs_call *call;
873 size_t namesz, reqsz, padsz;
874 __be32 *bp;
875
876 _enter("");
877
878 namesz = strlen(name);
879 padsz = (4 - (namesz & 3)) & 3;
880 reqsz = (5 * 4) + namesz + padsz + (3 * 4);
881
882 call = afs_alloc_flat_call(&afs_RXFSLink, reqsz, (21 + 21 + 6) * 4);
883 if (!call)
884 return -ENOMEM;
885
886 call->key = key;
887 call->reply = dvnode;
888 call->reply2 = vnode;
889 call->service_id = FS_SERVICE;
890 call->port = htons(AFS_FS_PORT);
891
892 /* marshall the parameters */
893 bp = call->request;
894 *bp++ = htonl(FSLINK);
895 *bp++ = htonl(dvnode->fid.vid);
896 *bp++ = htonl(dvnode->fid.vnode);
897 *bp++ = htonl(dvnode->fid.unique);
898 *bp++ = htonl(namesz);
899 memcpy(bp, name, namesz);
900 bp = (void *) bp + namesz;
901 if (padsz > 0) {
902 memset(bp, 0, padsz);
903 bp = (void *) bp + padsz;
904 }
905 *bp++ = htonl(vnode->fid.vid);
906 *bp++ = htonl(vnode->fid.vnode);
907 *bp++ = htonl(vnode->fid.unique);
908
909 return afs_make_call(&server->addr, call, GFP_NOFS, async);
910 }
911
912 /*
913 * deliver reply data to an FS.Symlink
914 */
915 static int afs_deliver_fs_symlink(struct afs_call *call)
916 {
917 struct afs_vnode *vnode = call->reply;
918 const __be32 *bp;
919 int ret;
920
921 _enter("{%u}", call->unmarshall);
922
923 ret = afs_transfer_reply(call);
924 if (ret < 0)
925 return ret;
926
927 /* unmarshall the reply once we've received all of it */
928 bp = call->buffer;
929 xdr_decode_AFSFid(&bp, call->reply2);
930 xdr_decode_AFSFetchStatus(&bp, call->reply3, NULL, NULL);
931 xdr_decode_AFSFetchStatus(&bp, &vnode->status, vnode, NULL);
932 /* xdr_decode_AFSVolSync(&bp, call->replyX); */
933
934 _leave(" = 0 [done]");
935 return 0;
936 }
937
938 /*
939 * FS.Symlink operation type
940 */
941 static const struct afs_call_type afs_RXFSSymlink = {
942 .name = "FS.Symlink",
943 .deliver = afs_deliver_fs_symlink,
944 .abort_to_error = afs_abort_to_error,
945 .destructor = afs_flat_call_destructor,
946 };
947
948 /*
949 * create a symbolic link
950 */
951 int afs_fs_symlink(struct afs_server *server,
952 struct key *key,
953 struct afs_vnode *vnode,
954 const char *name,
955 const char *contents,
956 struct afs_fid *newfid,
957 struct afs_file_status *newstatus,
958 bool async)
959 {
960 struct afs_call *call;
961 size_t namesz, reqsz, padsz, c_namesz, c_padsz;
962 __be32 *bp;
963
964 _enter("");
965
966 namesz = strlen(name);
967 padsz = (4 - (namesz & 3)) & 3;
968
969 c_namesz = strlen(contents);
970 c_padsz = (4 - (c_namesz & 3)) & 3;
971
972 reqsz = (6 * 4) + namesz + padsz + c_namesz + c_padsz + (6 * 4);
973
974 call = afs_alloc_flat_call(&afs_RXFSSymlink, reqsz,
975 (3 + 21 + 21 + 6) * 4);
976 if (!call)
977 return -ENOMEM;
978
979 call->key = key;
980 call->reply = vnode;
981 call->reply2 = newfid;
982 call->reply3 = newstatus;
983 call->service_id = FS_SERVICE;
984 call->port = htons(AFS_FS_PORT);
985
986 /* marshall the parameters */
987 bp = call->request;
988 *bp++ = htonl(FSSYMLINK);
989 *bp++ = htonl(vnode->fid.vid);
990 *bp++ = htonl(vnode->fid.vnode);
991 *bp++ = htonl(vnode->fid.unique);
992 *bp++ = htonl(namesz);
993 memcpy(bp, name, namesz);
994 bp = (void *) bp + namesz;
995 if (padsz > 0) {
996 memset(bp, 0, padsz);
997 bp = (void *) bp + padsz;
998 }
999 *bp++ = htonl(c_namesz);
1000 memcpy(bp, contents, c_namesz);
1001 bp = (void *) bp + c_namesz;
1002 if (c_padsz > 0) {
1003 memset(bp, 0, c_padsz);
1004 bp = (void *) bp + c_padsz;
1005 }
1006 *bp++ = htonl(AFS_SET_MODE | AFS_SET_MTIME);
1007 *bp++ = htonl(vnode->vfs_inode.i_mtime.tv_sec); /* mtime */
1008 *bp++ = 0; /* owner */
1009 *bp++ = 0; /* group */
1010 *bp++ = htonl(S_IRWXUGO); /* unix mode */
1011 *bp++ = 0; /* segment size */
1012
1013 return afs_make_call(&server->addr, call, GFP_NOFS, async);
1014 }
1015
1016 /*
1017 * deliver reply data to an FS.Rename
1018 */
1019 static int afs_deliver_fs_rename(struct afs_call *call)
1020 {
1021 struct afs_vnode *orig_dvnode = call->reply, *new_dvnode = call->reply2;
1022 const __be32 *bp;
1023 int ret;
1024
1025 _enter("{%u}", call->unmarshall);
1026
1027 ret = afs_transfer_reply(call);
1028 if (ret < 0)
1029 return ret;
1030
1031 /* unmarshall the reply once we've received all of it */
1032 bp = call->buffer;
1033 xdr_decode_AFSFetchStatus(&bp, &orig_dvnode->status, orig_dvnode, NULL);
1034 if (new_dvnode != orig_dvnode)
1035 xdr_decode_AFSFetchStatus(&bp, &new_dvnode->status, new_dvnode,
1036 NULL);
1037 /* xdr_decode_AFSVolSync(&bp, call->replyX); */
1038
1039 _leave(" = 0 [done]");
1040 return 0;
1041 }
1042
1043 /*
1044 * FS.Rename operation type
1045 */
1046 static const struct afs_call_type afs_RXFSRename = {
1047 .name = "FS.Rename",
1048 .deliver = afs_deliver_fs_rename,
1049 .abort_to_error = afs_abort_to_error,
1050 .destructor = afs_flat_call_destructor,
1051 };
1052
1053 /*
1054 * create a symbolic link
1055 */
1056 int afs_fs_rename(struct afs_server *server,
1057 struct key *key,
1058 struct afs_vnode *orig_dvnode,
1059 const char *orig_name,
1060 struct afs_vnode *new_dvnode,
1061 const char *new_name,
1062 bool async)
1063 {
1064 struct afs_call *call;
1065 size_t reqsz, o_namesz, o_padsz, n_namesz, n_padsz;
1066 __be32 *bp;
1067
1068 _enter("");
1069
1070 o_namesz = strlen(orig_name);
1071 o_padsz = (4 - (o_namesz & 3)) & 3;
1072
1073 n_namesz = strlen(new_name);
1074 n_padsz = (4 - (n_namesz & 3)) & 3;
1075
1076 reqsz = (4 * 4) +
1077 4 + o_namesz + o_padsz +
1078 (3 * 4) +
1079 4 + n_namesz + n_padsz;
1080
1081 call = afs_alloc_flat_call(&afs_RXFSRename, reqsz, (21 + 21 + 6) * 4);
1082 if (!call)
1083 return -ENOMEM;
1084
1085 call->key = key;
1086 call->reply = orig_dvnode;
1087 call->reply2 = new_dvnode;
1088 call->service_id = FS_SERVICE;
1089 call->port = htons(AFS_FS_PORT);
1090
1091 /* marshall the parameters */
1092 bp = call->request;
1093 *bp++ = htonl(FSRENAME);
1094 *bp++ = htonl(orig_dvnode->fid.vid);
1095 *bp++ = htonl(orig_dvnode->fid.vnode);
1096 *bp++ = htonl(orig_dvnode->fid.unique);
1097 *bp++ = htonl(o_namesz);
1098 memcpy(bp, orig_name, o_namesz);
1099 bp = (void *) bp + o_namesz;
1100 if (o_padsz > 0) {
1101 memset(bp, 0, o_padsz);
1102 bp = (void *) bp + o_padsz;
1103 }
1104
1105 *bp++ = htonl(new_dvnode->fid.vid);
1106 *bp++ = htonl(new_dvnode->fid.vnode);
1107 *bp++ = htonl(new_dvnode->fid.unique);
1108 *bp++ = htonl(n_namesz);
1109 memcpy(bp, new_name, n_namesz);
1110 bp = (void *) bp + n_namesz;
1111 if (n_padsz > 0) {
1112 memset(bp, 0, n_padsz);
1113 bp = (void *) bp + n_padsz;
1114 }
1115
1116 return afs_make_call(&server->addr, call, GFP_NOFS, async);
1117 }
1118
1119 /*
1120 * deliver reply data to an FS.StoreData
1121 */
1122 static int afs_deliver_fs_store_data(struct afs_call *call)
1123 {
1124 struct afs_vnode *vnode = call->reply;
1125 const __be32 *bp;
1126 int ret;
1127
1128 _enter("");
1129
1130 ret = afs_transfer_reply(call);
1131 if (ret < 0)
1132 return ret;
1133
1134 /* unmarshall the reply once we've received all of it */
1135 bp = call->buffer;
1136 xdr_decode_AFSFetchStatus(&bp, &vnode->status, vnode,
1137 &call->store_version);
1138 /* xdr_decode_AFSVolSync(&bp, call->replyX); */
1139
1140 afs_pages_written_back(vnode, call);
1141
1142 _leave(" = 0 [done]");
1143 return 0;
1144 }
1145
1146 /*
1147 * FS.StoreData operation type
1148 */
1149 static const struct afs_call_type afs_RXFSStoreData = {
1150 .name = "FS.StoreData",
1151 .deliver = afs_deliver_fs_store_data,
1152 .abort_to_error = afs_abort_to_error,
1153 .destructor = afs_flat_call_destructor,
1154 };
1155
1156 static const struct afs_call_type afs_RXFSStoreData64 = {
1157 .name = "FS.StoreData64",
1158 .deliver = afs_deliver_fs_store_data,
1159 .abort_to_error = afs_abort_to_error,
1160 .destructor = afs_flat_call_destructor,
1161 };
1162
1163 /*
1164 * store a set of pages to a very large file
1165 */
1166 static int afs_fs_store_data64(struct afs_server *server,
1167 struct afs_writeback *wb,
1168 pgoff_t first, pgoff_t last,
1169 unsigned offset, unsigned to,
1170 loff_t size, loff_t pos, loff_t i_size,
1171 bool async)
1172 {
1173 struct afs_vnode *vnode = wb->vnode;
1174 struct afs_call *call;
1175 __be32 *bp;
1176
1177 _enter(",%x,{%x:%u},,",
1178 key_serial(wb->key), vnode->fid.vid, vnode->fid.vnode);
1179
1180 call = afs_alloc_flat_call(&afs_RXFSStoreData64,
1181 (4 + 6 + 3 * 2) * 4,
1182 (21 + 6) * 4);
1183 if (!call)
1184 return -ENOMEM;
1185
1186 call->wb = wb;
1187 call->key = wb->key;
1188 call->reply = vnode;
1189 call->service_id = FS_SERVICE;
1190 call->port = htons(AFS_FS_PORT);
1191 call->mapping = vnode->vfs_inode.i_mapping;
1192 call->first = first;
1193 call->last = last;
1194 call->first_offset = offset;
1195 call->last_to = to;
1196 call->send_pages = true;
1197 call->store_version = vnode->status.data_version + 1;
1198
1199 /* marshall the parameters */
1200 bp = call->request;
1201 *bp++ = htonl(FSSTOREDATA64);
1202 *bp++ = htonl(vnode->fid.vid);
1203 *bp++ = htonl(vnode->fid.vnode);
1204 *bp++ = htonl(vnode->fid.unique);
1205
1206 *bp++ = htonl(AFS_SET_MTIME); /* mask */
1207 *bp++ = htonl(vnode->vfs_inode.i_mtime.tv_sec); /* mtime */
1208 *bp++ = 0; /* owner */
1209 *bp++ = 0; /* group */
1210 *bp++ = 0; /* unix mode */
1211 *bp++ = 0; /* segment size */
1212
1213 *bp++ = htonl(pos >> 32);
1214 *bp++ = htonl((u32) pos);
1215 *bp++ = htonl(size >> 32);
1216 *bp++ = htonl((u32) size);
1217 *bp++ = htonl(i_size >> 32);
1218 *bp++ = htonl((u32) i_size);
1219
1220 return afs_make_call(&server->addr, call, GFP_NOFS, async);
1221 }
1222
1223 /*
1224 * store a set of pages
1225 */
1226 int afs_fs_store_data(struct afs_server *server, struct afs_writeback *wb,
1227 pgoff_t first, pgoff_t last,
1228 unsigned offset, unsigned to,
1229 bool async)
1230 {
1231 struct afs_vnode *vnode = wb->vnode;
1232 struct afs_call *call;
1233 loff_t size, pos, i_size;
1234 __be32 *bp;
1235
1236 _enter(",%x,{%x:%u},,",
1237 key_serial(wb->key), vnode->fid.vid, vnode->fid.vnode);
1238
1239 size = (loff_t)to - (loff_t)offset;
1240 if (first != last)
1241 size += (loff_t)(last - first) << PAGE_SHIFT;
1242 pos = (loff_t)first << PAGE_SHIFT;
1243 pos += offset;
1244
1245 i_size = i_size_read(&vnode->vfs_inode);
1246 if (pos + size > i_size)
1247 i_size = size + pos;
1248
1249 _debug("size %llx, at %llx, i_size %llx",
1250 (unsigned long long) size, (unsigned long long) pos,
1251 (unsigned long long) i_size);
1252
1253 if (pos >> 32 || i_size >> 32 || size >> 32 || (pos + size) >> 32)
1254 return afs_fs_store_data64(server, wb, first, last, offset, to,
1255 size, pos, i_size, async);
1256
1257 call = afs_alloc_flat_call(&afs_RXFSStoreData,
1258 (4 + 6 + 3) * 4,
1259 (21 + 6) * 4);
1260 if (!call)
1261 return -ENOMEM;
1262
1263 call->wb = wb;
1264 call->key = wb->key;
1265 call->reply = vnode;
1266 call->service_id = FS_SERVICE;
1267 call->port = htons(AFS_FS_PORT);
1268 call->mapping = vnode->vfs_inode.i_mapping;
1269 call->first = first;
1270 call->last = last;
1271 call->first_offset = offset;
1272 call->last_to = to;
1273 call->send_pages = true;
1274 call->store_version = vnode->status.data_version + 1;
1275
1276 /* marshall the parameters */
1277 bp = call->request;
1278 *bp++ = htonl(FSSTOREDATA);
1279 *bp++ = htonl(vnode->fid.vid);
1280 *bp++ = htonl(vnode->fid.vnode);
1281 *bp++ = htonl(vnode->fid.unique);
1282
1283 *bp++ = htonl(AFS_SET_MTIME); /* mask */
1284 *bp++ = htonl(vnode->vfs_inode.i_mtime.tv_sec); /* mtime */
1285 *bp++ = 0; /* owner */
1286 *bp++ = 0; /* group */
1287 *bp++ = 0; /* unix mode */
1288 *bp++ = 0; /* segment size */
1289
1290 *bp++ = htonl(pos);
1291 *bp++ = htonl(size);
1292 *bp++ = htonl(i_size);
1293
1294 return afs_make_call(&server->addr, call, GFP_NOFS, async);
1295 }
1296
1297 /*
1298 * deliver reply data to an FS.StoreStatus
1299 */
1300 static int afs_deliver_fs_store_status(struct afs_call *call)
1301 {
1302 afs_dataversion_t *store_version;
1303 struct afs_vnode *vnode = call->reply;
1304 const __be32 *bp;
1305 int ret;
1306
1307 _enter("");
1308
1309 ret = afs_transfer_reply(call);
1310 if (ret < 0)
1311 return ret;
1312
1313 /* unmarshall the reply once we've received all of it */
1314 store_version = NULL;
1315 if (call->operation_ID == FSSTOREDATA)
1316 store_version = &call->store_version;
1317
1318 bp = call->buffer;
1319 xdr_decode_AFSFetchStatus(&bp, &vnode->status, vnode, store_version);
1320 /* xdr_decode_AFSVolSync(&bp, call->replyX); */
1321
1322 _leave(" = 0 [done]");
1323 return 0;
1324 }
1325
1326 /*
1327 * FS.StoreStatus operation type
1328 */
1329 static const struct afs_call_type afs_RXFSStoreStatus = {
1330 .name = "FS.StoreStatus",
1331 .deliver = afs_deliver_fs_store_status,
1332 .abort_to_error = afs_abort_to_error,
1333 .destructor = afs_flat_call_destructor,
1334 };
1335
1336 static const struct afs_call_type afs_RXFSStoreData_as_Status = {
1337 .name = "FS.StoreData",
1338 .deliver = afs_deliver_fs_store_status,
1339 .abort_to_error = afs_abort_to_error,
1340 .destructor = afs_flat_call_destructor,
1341 };
1342
1343 static const struct afs_call_type afs_RXFSStoreData64_as_Status = {
1344 .name = "FS.StoreData64",
1345 .deliver = afs_deliver_fs_store_status,
1346 .abort_to_error = afs_abort_to_error,
1347 .destructor = afs_flat_call_destructor,
1348 };
1349
1350 /*
1351 * set the attributes on a very large file, using FS.StoreData rather than
1352 * FS.StoreStatus so as to alter the file size also
1353 */
1354 static int afs_fs_setattr_size64(struct afs_server *server, struct key *key,
1355 struct afs_vnode *vnode, struct iattr *attr,
1356 bool async)
1357 {
1358 struct afs_call *call;
1359 __be32 *bp;
1360
1361 _enter(",%x,{%x:%u},,",
1362 key_serial(key), vnode->fid.vid, vnode->fid.vnode);
1363
1364 ASSERT(attr->ia_valid & ATTR_SIZE);
1365
1366 call = afs_alloc_flat_call(&afs_RXFSStoreData64_as_Status,
1367 (4 + 6 + 3 * 2) * 4,
1368 (21 + 6) * 4);
1369 if (!call)
1370 return -ENOMEM;
1371
1372 call->key = key;
1373 call->reply = vnode;
1374 call->service_id = FS_SERVICE;
1375 call->port = htons(AFS_FS_PORT);
1376 call->store_version = vnode->status.data_version + 1;
1377 call->operation_ID = FSSTOREDATA;
1378
1379 /* marshall the parameters */
1380 bp = call->request;
1381 *bp++ = htonl(FSSTOREDATA64);
1382 *bp++ = htonl(vnode->fid.vid);
1383 *bp++ = htonl(vnode->fid.vnode);
1384 *bp++ = htonl(vnode->fid.unique);
1385
1386 xdr_encode_AFS_StoreStatus(&bp, attr);
1387
1388 *bp++ = 0; /* position of start of write */
1389 *bp++ = 0;
1390 *bp++ = 0; /* size of write */
1391 *bp++ = 0;
1392 *bp++ = htonl(attr->ia_size >> 32); /* new file length */
1393 *bp++ = htonl((u32) attr->ia_size);
1394
1395 return afs_make_call(&server->addr, call, GFP_NOFS, async);
1396 }
1397
1398 /*
1399 * set the attributes on a file, using FS.StoreData rather than FS.StoreStatus
1400 * so as to alter the file size also
1401 */
1402 static int afs_fs_setattr_size(struct afs_server *server, struct key *key,
1403 struct afs_vnode *vnode, struct iattr *attr,
1404 bool async)
1405 {
1406 struct afs_call *call;
1407 __be32 *bp;
1408
1409 _enter(",%x,{%x:%u},,",
1410 key_serial(key), vnode->fid.vid, vnode->fid.vnode);
1411
1412 ASSERT(attr->ia_valid & ATTR_SIZE);
1413 if (attr->ia_size >> 32)
1414 return afs_fs_setattr_size64(server, key, vnode, attr,
1415 async);
1416
1417 call = afs_alloc_flat_call(&afs_RXFSStoreData_as_Status,
1418 (4 + 6 + 3) * 4,
1419 (21 + 6) * 4);
1420 if (!call)
1421 return -ENOMEM;
1422
1423 call->key = key;
1424 call->reply = vnode;
1425 call->service_id = FS_SERVICE;
1426 call->port = htons(AFS_FS_PORT);
1427 call->store_version = vnode->status.data_version + 1;
1428 call->operation_ID = FSSTOREDATA;
1429
1430 /* marshall the parameters */
1431 bp = call->request;
1432 *bp++ = htonl(FSSTOREDATA);
1433 *bp++ = htonl(vnode->fid.vid);
1434 *bp++ = htonl(vnode->fid.vnode);
1435 *bp++ = htonl(vnode->fid.unique);
1436
1437 xdr_encode_AFS_StoreStatus(&bp, attr);
1438
1439 *bp++ = 0; /* position of start of write */
1440 *bp++ = 0; /* size of write */
1441 *bp++ = htonl(attr->ia_size); /* new file length */
1442
1443 return afs_make_call(&server->addr, call, GFP_NOFS, async);
1444 }
1445
1446 /*
1447 * set the attributes on a file, using FS.StoreData if there's a change in file
1448 * size, and FS.StoreStatus otherwise
1449 */
1450 int afs_fs_setattr(struct afs_server *server, struct key *key,
1451 struct afs_vnode *vnode, struct iattr *attr,
1452 bool async)
1453 {
1454 struct afs_call *call;
1455 __be32 *bp;
1456
1457 if (attr->ia_valid & ATTR_SIZE)
1458 return afs_fs_setattr_size(server, key, vnode, attr,
1459 async);
1460
1461 _enter(",%x,{%x:%u},,",
1462 key_serial(key), vnode->fid.vid, vnode->fid.vnode);
1463
1464 call = afs_alloc_flat_call(&afs_RXFSStoreStatus,
1465 (4 + 6) * 4,
1466 (21 + 6) * 4);
1467 if (!call)
1468 return -ENOMEM;
1469
1470 call->key = key;
1471 call->reply = vnode;
1472 call->service_id = FS_SERVICE;
1473 call->port = htons(AFS_FS_PORT);
1474 call->operation_ID = FSSTORESTATUS;
1475
1476 /* marshall the parameters */
1477 bp = call->request;
1478 *bp++ = htonl(FSSTORESTATUS);
1479 *bp++ = htonl(vnode->fid.vid);
1480 *bp++ = htonl(vnode->fid.vnode);
1481 *bp++ = htonl(vnode->fid.unique);
1482
1483 xdr_encode_AFS_StoreStatus(&bp, attr);
1484
1485 return afs_make_call(&server->addr, call, GFP_NOFS, async);
1486 }
1487
1488 /*
1489 * deliver reply data to an FS.GetVolumeStatus
1490 */
1491 static int afs_deliver_fs_get_volume_status(struct afs_call *call)
1492 {
1493 const __be32 *bp;
1494 char *p;
1495 int ret;
1496
1497 _enter("{%u}", call->unmarshall);
1498
1499 switch (call->unmarshall) {
1500 case 0:
1501 call->offset = 0;
1502 call->unmarshall++;
1503
1504 /* extract the returned status record */
1505 case 1:
1506 _debug("extract status");
1507 ret = afs_extract_data(call, call->buffer,
1508 12 * 4, true);
1509 if (ret < 0)
1510 return ret;
1511
1512 bp = call->buffer;
1513 xdr_decode_AFSFetchVolumeStatus(&bp, call->reply2);
1514 call->offset = 0;
1515 call->unmarshall++;
1516
1517 /* extract the volume name length */
1518 case 2:
1519 ret = afs_extract_data(call, &call->tmp, 4, true);
1520 if (ret < 0)
1521 return ret;
1522
1523 call->count = ntohl(call->tmp);
1524 _debug("volname length: %u", call->count);
1525 if (call->count >= AFSNAMEMAX)
1526 return -EBADMSG;
1527 call->offset = 0;
1528 call->unmarshall++;
1529
1530 /* extract the volume name */
1531 case 3:
1532 _debug("extract volname");
1533 if (call->count > 0) {
1534 ret = afs_extract_data(call, call->reply3,
1535 call->count, true);
1536 if (ret < 0)
1537 return ret;
1538 }
1539
1540 p = call->reply3;
1541 p[call->count] = 0;
1542 _debug("volname '%s'", p);
1543
1544 call->offset = 0;
1545 call->unmarshall++;
1546
1547 /* extract the volume name padding */
1548 if ((call->count & 3) == 0) {
1549 call->unmarshall++;
1550 goto no_volname_padding;
1551 }
1552 call->count = 4 - (call->count & 3);
1553
1554 case 4:
1555 ret = afs_extract_data(call, call->buffer,
1556 call->count, true);
1557 if (ret < 0)
1558 return ret;
1559
1560 call->offset = 0;
1561 call->unmarshall++;
1562 no_volname_padding:
1563
1564 /* extract the offline message length */
1565 case 5:
1566 ret = afs_extract_data(call, &call->tmp, 4, true);
1567 if (ret < 0)
1568 return ret;
1569
1570 call->count = ntohl(call->tmp);
1571 _debug("offline msg length: %u", call->count);
1572 if (call->count >= AFSNAMEMAX)
1573 return -EBADMSG;
1574 call->offset = 0;
1575 call->unmarshall++;
1576
1577 /* extract the offline message */
1578 case 6:
1579 _debug("extract offline");
1580 if (call->count > 0) {
1581 ret = afs_extract_data(call, call->reply3,
1582 call->count, true);
1583 if (ret < 0)
1584 return ret;
1585 }
1586
1587 p = call->reply3;
1588 p[call->count] = 0;
1589 _debug("offline '%s'", p);
1590
1591 call->offset = 0;
1592 call->unmarshall++;
1593
1594 /* extract the offline message padding */
1595 if ((call->count & 3) == 0) {
1596 call->unmarshall++;
1597 goto no_offline_padding;
1598 }
1599 call->count = 4 - (call->count & 3);
1600
1601 case 7:
1602 ret = afs_extract_data(call, call->buffer,
1603 call->count, true);
1604 if (ret < 0)
1605 return ret;
1606
1607 call->offset = 0;
1608 call->unmarshall++;
1609 no_offline_padding:
1610
1611 /* extract the message of the day length */
1612 case 8:
1613 ret = afs_extract_data(call, &call->tmp, 4, true);
1614 if (ret < 0)
1615 return ret;
1616
1617 call->count = ntohl(call->tmp);
1618 _debug("motd length: %u", call->count);
1619 if (call->count >= AFSNAMEMAX)
1620 return -EBADMSG;
1621 call->offset = 0;
1622 call->unmarshall++;
1623
1624 /* extract the message of the day */
1625 case 9:
1626 _debug("extract motd");
1627 if (call->count > 0) {
1628 ret = afs_extract_data(call, call->reply3,
1629 call->count, true);
1630 if (ret < 0)
1631 return ret;
1632 }
1633
1634 p = call->reply3;
1635 p[call->count] = 0;
1636 _debug("motd '%s'", p);
1637
1638 call->offset = 0;
1639 call->unmarshall++;
1640
1641 /* extract the message of the day padding */
1642 call->count = (4 - (call->count & 3)) & 3;
1643
1644 case 10:
1645 ret = afs_extract_data(call, call->buffer,
1646 call->count, false);
1647 if (ret < 0)
1648 return ret;
1649
1650 call->offset = 0;
1651 call->unmarshall++;
1652 case 11:
1653 break;
1654 }
1655
1656 _leave(" = 0 [done]");
1657 return 0;
1658 }
1659
1660 /*
1661 * destroy an FS.GetVolumeStatus call
1662 */
1663 static void afs_get_volume_status_call_destructor(struct afs_call *call)
1664 {
1665 kfree(call->reply3);
1666 call->reply3 = NULL;
1667 afs_flat_call_destructor(call);
1668 }
1669
1670 /*
1671 * FS.GetVolumeStatus operation type
1672 */
1673 static const struct afs_call_type afs_RXFSGetVolumeStatus = {
1674 .name = "FS.GetVolumeStatus",
1675 .deliver = afs_deliver_fs_get_volume_status,
1676 .abort_to_error = afs_abort_to_error,
1677 .destructor = afs_get_volume_status_call_destructor,
1678 };
1679
1680 /*
1681 * fetch the status of a volume
1682 */
1683 int afs_fs_get_volume_status(struct afs_server *server,
1684 struct key *key,
1685 struct afs_vnode *vnode,
1686 struct afs_volume_status *vs,
1687 bool async)
1688 {
1689 struct afs_call *call;
1690 __be32 *bp;
1691 void *tmpbuf;
1692
1693 _enter("");
1694
1695 tmpbuf = kmalloc(AFSOPAQUEMAX, GFP_KERNEL);
1696 if (!tmpbuf)
1697 return -ENOMEM;
1698
1699 call = afs_alloc_flat_call(&afs_RXFSGetVolumeStatus, 2 * 4, 12 * 4);
1700 if (!call) {
1701 kfree(tmpbuf);
1702 return -ENOMEM;
1703 }
1704
1705 call->key = key;
1706 call->reply = vnode;
1707 call->reply2 = vs;
1708 call->reply3 = tmpbuf;
1709 call->service_id = FS_SERVICE;
1710 call->port = htons(AFS_FS_PORT);
1711
1712 /* marshall the parameters */
1713 bp = call->request;
1714 bp[0] = htonl(FSGETVOLUMESTATUS);
1715 bp[1] = htonl(vnode->fid.vid);
1716
1717 return afs_make_call(&server->addr, call, GFP_NOFS, async);
1718 }
1719
1720 /*
1721 * deliver reply data to an FS.SetLock, FS.ExtendLock or FS.ReleaseLock
1722 */
1723 static int afs_deliver_fs_xxxx_lock(struct afs_call *call)
1724 {
1725 const __be32 *bp;
1726 int ret;
1727
1728 _enter("{%u}", call->unmarshall);
1729
1730 ret = afs_transfer_reply(call);
1731 if (ret < 0)
1732 return ret;
1733
1734 /* unmarshall the reply once we've received all of it */
1735 bp = call->buffer;
1736 /* xdr_decode_AFSVolSync(&bp, call->replyX); */
1737
1738 _leave(" = 0 [done]");
1739 return 0;
1740 }
1741
1742 /*
1743 * FS.SetLock operation type
1744 */
1745 static const struct afs_call_type afs_RXFSSetLock = {
1746 .name = "FS.SetLock",
1747 .deliver = afs_deliver_fs_xxxx_lock,
1748 .abort_to_error = afs_abort_to_error,
1749 .destructor = afs_flat_call_destructor,
1750 };
1751
1752 /*
1753 * FS.ExtendLock operation type
1754 */
1755 static const struct afs_call_type afs_RXFSExtendLock = {
1756 .name = "FS.ExtendLock",
1757 .deliver = afs_deliver_fs_xxxx_lock,
1758 .abort_to_error = afs_abort_to_error,
1759 .destructor = afs_flat_call_destructor,
1760 };
1761
1762 /*
1763 * FS.ReleaseLock operation type
1764 */
1765 static const struct afs_call_type afs_RXFSReleaseLock = {
1766 .name = "FS.ReleaseLock",
1767 .deliver = afs_deliver_fs_xxxx_lock,
1768 .abort_to_error = afs_abort_to_error,
1769 .destructor = afs_flat_call_destructor,
1770 };
1771
1772 /*
1773 * get a lock on a file
1774 */
1775 int afs_fs_set_lock(struct afs_server *server,
1776 struct key *key,
1777 struct afs_vnode *vnode,
1778 afs_lock_type_t type,
1779 bool async)
1780 {
1781 struct afs_call *call;
1782 __be32 *bp;
1783
1784 _enter("");
1785
1786 call = afs_alloc_flat_call(&afs_RXFSSetLock, 5 * 4, 6 * 4);
1787 if (!call)
1788 return -ENOMEM;
1789
1790 call->key = key;
1791 call->reply = vnode;
1792 call->service_id = FS_SERVICE;
1793 call->port = htons(AFS_FS_PORT);
1794
1795 /* marshall the parameters */
1796 bp = call->request;
1797 *bp++ = htonl(FSSETLOCK);
1798 *bp++ = htonl(vnode->fid.vid);
1799 *bp++ = htonl(vnode->fid.vnode);
1800 *bp++ = htonl(vnode->fid.unique);
1801 *bp++ = htonl(type);
1802
1803 return afs_make_call(&server->addr, call, GFP_NOFS, async);
1804 }
1805
1806 /*
1807 * extend a lock on a file
1808 */
1809 int afs_fs_extend_lock(struct afs_server *server,
1810 struct key *key,
1811 struct afs_vnode *vnode,
1812 bool async)
1813 {
1814 struct afs_call *call;
1815 __be32 *bp;
1816
1817 _enter("");
1818
1819 call = afs_alloc_flat_call(&afs_RXFSExtendLock, 4 * 4, 6 * 4);
1820 if (!call)
1821 return -ENOMEM;
1822
1823 call->key = key;
1824 call->reply = vnode;
1825 call->service_id = FS_SERVICE;
1826 call->port = htons(AFS_FS_PORT);
1827
1828 /* marshall the parameters */
1829 bp = call->request;
1830 *bp++ = htonl(FSEXTENDLOCK);
1831 *bp++ = htonl(vnode->fid.vid);
1832 *bp++ = htonl(vnode->fid.vnode);
1833 *bp++ = htonl(vnode->fid.unique);
1834
1835 return afs_make_call(&server->addr, call, GFP_NOFS, async);
1836 }
1837
1838 /*
1839 * release a lock on a file
1840 */
1841 int afs_fs_release_lock(struct afs_server *server,
1842 struct key *key,
1843 struct afs_vnode *vnode,
1844 bool async)
1845 {
1846 struct afs_call *call;
1847 __be32 *bp;
1848
1849 _enter("");
1850
1851 call = afs_alloc_flat_call(&afs_RXFSReleaseLock, 4 * 4, 6 * 4);
1852 if (!call)
1853 return -ENOMEM;
1854
1855 call->key = key;
1856 call->reply = vnode;
1857 call->service_id = FS_SERVICE;
1858 call->port = htons(AFS_FS_PORT);
1859
1860 /* marshall the parameters */
1861 bp = call->request;
1862 *bp++ = htonl(FSRELEASELOCK);
1863 *bp++ = htonl(vnode->fid.vid);
1864 *bp++ = htonl(vnode->fid.vnode);
1865 *bp++ = htonl(vnode->fid.unique);
1866
1867 return afs_make_call(&server->addr, call, GFP_NOFS, async);
1868 }
Linux with added FPC-III support