Merge tag 's390-4.20-2' of git://git.kernel.org/pub/scm/linux/kernel/git/s390/linux
[linux-2.6-block.git] / fs / afs / vlclient.c
1 /* AFS Volume Location Service client
2  *
3  * Copyright (C) 2002 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/gfp.h>
13 #include <linux/init.h>
14 #include <linux/sched.h>
15 #include "afs_fs.h"
16 #include "internal.h"
17
18 /*
19  * Deliver reply data to a VL.GetEntryByNameU call.
20  */
21 static int afs_deliver_vl_get_entry_by_name_u(struct afs_call *call)
22 {
23         struct afs_uvldbentry__xdr *uvldb;
24         struct afs_vldb_entry *entry;
25         bool new_only = false;
26         u32 tmp, nr_servers, vlflags;
27         int i, ret;
28
29         _enter("");
30
31         ret = afs_transfer_reply(call);
32         if (ret < 0)
33                 return ret;
34
35         /* unmarshall the reply once we've received all of it */
36         uvldb = call->buffer;
37         entry = call->reply[0];
38
39         nr_servers = ntohl(uvldb->nServers);
40         if (nr_servers > AFS_NMAXNSERVERS)
41                 nr_servers = AFS_NMAXNSERVERS;
42
43         for (i = 0; i < ARRAY_SIZE(uvldb->name) - 1; i++)
44                 entry->name[i] = (u8)ntohl(uvldb->name[i]);
45         entry->name[i] = 0;
46         entry->name_len = strlen(entry->name);
47
48         /* If there is a new replication site that we can use, ignore all the
49          * sites that aren't marked as new.
50          */
51         for (i = 0; i < nr_servers; i++) {
52                 tmp = ntohl(uvldb->serverFlags[i]);
53                 if (!(tmp & AFS_VLSF_DONTUSE) &&
54                     (tmp & AFS_VLSF_NEWREPSITE))
55                         new_only = true;
56         }
57
58         vlflags = ntohl(uvldb->flags);
59         for (i = 0; i < nr_servers; i++) {
60                 struct afs_uuid__xdr *xdr;
61                 struct afs_uuid *uuid;
62                 int j;
63
64                 tmp = ntohl(uvldb->serverFlags[i]);
65                 if (tmp & AFS_VLSF_DONTUSE ||
66                     (new_only && !(tmp & AFS_VLSF_NEWREPSITE)))
67                         continue;
68                 if (tmp & AFS_VLSF_RWVOL) {
69                         entry->fs_mask[i] |= AFS_VOL_VTM_RW;
70                         if (vlflags & AFS_VLF_BACKEXISTS)
71                                 entry->fs_mask[i] |= AFS_VOL_VTM_BAK;
72                 }
73                 if (tmp & AFS_VLSF_ROVOL)
74                         entry->fs_mask[i] |= AFS_VOL_VTM_RO;
75                 if (!entry->fs_mask[i])
76                         continue;
77
78                 xdr = &uvldb->serverNumber[i];
79                 uuid = (struct afs_uuid *)&entry->fs_server[i];
80                 uuid->time_low                  = xdr->time_low;
81                 uuid->time_mid                  = htons(ntohl(xdr->time_mid));
82                 uuid->time_hi_and_version       = htons(ntohl(xdr->time_hi_and_version));
83                 uuid->clock_seq_hi_and_reserved = (u8)ntohl(xdr->clock_seq_hi_and_reserved);
84                 uuid->clock_seq_low             = (u8)ntohl(xdr->clock_seq_low);
85                 for (j = 0; j < 6; j++)
86                         uuid->node[j] = (u8)ntohl(xdr->node[j]);
87
88                 entry->nr_servers++;
89         }
90
91         for (i = 0; i < AFS_MAXTYPES; i++)
92                 entry->vid[i] = ntohl(uvldb->volumeId[i]);
93
94         if (vlflags & AFS_VLF_RWEXISTS)
95                 __set_bit(AFS_VLDB_HAS_RW, &entry->flags);
96         if (vlflags & AFS_VLF_ROEXISTS)
97                 __set_bit(AFS_VLDB_HAS_RO, &entry->flags);
98         if (vlflags & AFS_VLF_BACKEXISTS)
99                 __set_bit(AFS_VLDB_HAS_BAK, &entry->flags);
100
101         if (!(vlflags & (AFS_VLF_RWEXISTS | AFS_VLF_ROEXISTS | AFS_VLF_BACKEXISTS))) {
102                 entry->error = -ENOMEDIUM;
103                 __set_bit(AFS_VLDB_QUERY_ERROR, &entry->flags);
104         }
105
106         __set_bit(AFS_VLDB_QUERY_VALID, &entry->flags);
107         _leave(" = 0 [done]");
108         return 0;
109 }
110
111 static void afs_destroy_vl_get_entry_by_name_u(struct afs_call *call)
112 {
113         kfree(call->reply[0]);
114         afs_flat_call_destructor(call);
115 }
116
117 /*
118  * VL.GetEntryByNameU operation type.
119  */
120 static const struct afs_call_type afs_RXVLGetEntryByNameU = {
121         .name           = "VL.GetEntryByNameU",
122         .op             = afs_VL_GetEntryByNameU,
123         .deliver        = afs_deliver_vl_get_entry_by_name_u,
124         .destructor     = afs_destroy_vl_get_entry_by_name_u,
125 };
126
127 /*
128  * Dispatch a get volume entry by name or ID operation (uuid variant).  If the
129  * volname is a decimal number then it's a volume ID not a volume name.
130  */
131 struct afs_vldb_entry *afs_vl_get_entry_by_name_u(struct afs_vl_cursor *vc,
132                                                   const char *volname,
133                                                   int volnamesz)
134 {
135         struct afs_vldb_entry *entry;
136         struct afs_call *call;
137         struct afs_net *net = vc->cell->net;
138         size_t reqsz, padsz;
139         __be32 *bp;
140
141         _enter("");
142
143         padsz = (4 - (volnamesz & 3)) & 3;
144         reqsz = 8 + volnamesz + padsz;
145
146         entry = kzalloc(sizeof(struct afs_vldb_entry), GFP_KERNEL);
147         if (!entry)
148                 return ERR_PTR(-ENOMEM);
149
150         call = afs_alloc_flat_call(net, &afs_RXVLGetEntryByNameU, reqsz,
151                                    sizeof(struct afs_uvldbentry__xdr));
152         if (!call) {
153                 kfree(entry);
154                 return ERR_PTR(-ENOMEM);
155         }
156
157         call->key = vc->key;
158         call->reply[0] = entry;
159         call->ret_reply0 = true;
160
161         /* Marshall the parameters */
162         bp = call->request;
163         *bp++ = htonl(VLGETENTRYBYNAMEU);
164         *bp++ = htonl(volnamesz);
165         memcpy(bp, volname, volnamesz);
166         if (padsz > 0)
167                 memset((void *)bp + volnamesz, 0, padsz);
168
169         trace_afs_make_vl_call(call);
170         return (struct afs_vldb_entry *)afs_make_call(&vc->ac, call, GFP_KERNEL, false);
171 }
172
173 /*
174  * Deliver reply data to a VL.GetAddrsU call.
175  *
176  *      GetAddrsU(IN ListAddrByAttributes *inaddr,
177  *                OUT afsUUID *uuidp1,
178  *                OUT uint32_t *uniquifier,
179  *                OUT uint32_t *nentries,
180  *                OUT bulkaddrs *blkaddrs);
181  */
182 static int afs_deliver_vl_get_addrs_u(struct afs_call *call)
183 {
184         struct afs_addr_list *alist;
185         __be32 *bp;
186         u32 uniquifier, nentries, count;
187         int i, ret;
188
189         _enter("{%u,%zu/%u}",
190                call->unmarshall, iov_iter_count(call->_iter), call->count);
191
192         switch (call->unmarshall) {
193         case 0:
194                 afs_extract_to_buf(call,
195                                    sizeof(struct afs_uuid__xdr) + 3 * sizeof(__be32));
196                 call->unmarshall++;
197
198                 /* Extract the returned uuid, uniquifier, nentries and blkaddrs size */
199         case 1:
200                 ret = afs_extract_data(call, true);
201                 if (ret < 0)
202                         return ret;
203
204                 bp = call->buffer + sizeof(struct afs_uuid__xdr);
205                 uniquifier      = ntohl(*bp++);
206                 nentries        = ntohl(*bp++);
207                 count           = ntohl(*bp);
208
209                 nentries = min(nentries, count);
210                 alist = afs_alloc_addrlist(nentries, FS_SERVICE, AFS_FS_PORT);
211                 if (!alist)
212                         return -ENOMEM;
213                 alist->version = uniquifier;
214                 call->reply[0] = alist;
215                 call->count = count;
216                 call->count2 = nentries;
217                 call->unmarshall++;
218
219         more_entries:
220                 count = min(call->count, 4U);
221                 afs_extract_to_buf(call, count * sizeof(__be32));
222
223                 /* Extract entries */
224         case 2:
225                 ret = afs_extract_data(call, call->count > 4);
226                 if (ret < 0)
227                         return ret;
228
229                 alist = call->reply[0];
230                 bp = call->buffer;
231                 count = min(call->count, 4U);
232                 for (i = 0; i < count; i++)
233                         if (alist->nr_addrs < call->count2)
234                                 afs_merge_fs_addr4(alist, *bp++, AFS_FS_PORT);
235
236                 call->count -= count;
237                 if (call->count > 0)
238                         goto more_entries;
239                 call->unmarshall++;
240                 break;
241         }
242
243         _leave(" = 0 [done]");
244         return 0;
245 }
246
247 static void afs_vl_get_addrs_u_destructor(struct afs_call *call)
248 {
249         afs_put_server(call->net, (struct afs_server *)call->reply[0]);
250         kfree(call->reply[1]);
251         return afs_flat_call_destructor(call);
252 }
253
254 /*
255  * VL.GetAddrsU operation type.
256  */
257 static const struct afs_call_type afs_RXVLGetAddrsU = {
258         .name           = "VL.GetAddrsU",
259         .op             = afs_VL_GetAddrsU,
260         .deliver        = afs_deliver_vl_get_addrs_u,
261         .destructor     = afs_vl_get_addrs_u_destructor,
262 };
263
264 /*
265  * Dispatch an operation to get the addresses for a server, where the server is
266  * nominated by UUID.
267  */
268 struct afs_addr_list *afs_vl_get_addrs_u(struct afs_vl_cursor *vc,
269                                          const uuid_t *uuid)
270 {
271         struct afs_ListAddrByAttributes__xdr *r;
272         const struct afs_uuid *u = (const struct afs_uuid *)uuid;
273         struct afs_call *call;
274         struct afs_net *net = vc->cell->net;
275         __be32 *bp;
276         int i;
277
278         _enter("");
279
280         call = afs_alloc_flat_call(net, &afs_RXVLGetAddrsU,
281                                    sizeof(__be32) + sizeof(struct afs_ListAddrByAttributes__xdr),
282                                    sizeof(struct afs_uuid__xdr) + 3 * sizeof(__be32));
283         if (!call)
284                 return ERR_PTR(-ENOMEM);
285
286         call->key = vc->key;
287         call->reply[0] = NULL;
288         call->ret_reply0 = true;
289
290         /* Marshall the parameters */
291         bp = call->request;
292         *bp++ = htonl(VLGETADDRSU);
293         r = (struct afs_ListAddrByAttributes__xdr *)bp;
294         r->Mask         = htonl(AFS_VLADDR_UUID);
295         r->ipaddr       = 0;
296         r->index        = 0;
297         r->spare        = 0;
298         r->uuid.time_low                        = u->time_low;
299         r->uuid.time_mid                        = htonl(ntohs(u->time_mid));
300         r->uuid.time_hi_and_version             = htonl(ntohs(u->time_hi_and_version));
301         r->uuid.clock_seq_hi_and_reserved       = htonl(u->clock_seq_hi_and_reserved);
302         r->uuid.clock_seq_low                   = htonl(u->clock_seq_low);
303         for (i = 0; i < 6; i++)
304                 r->uuid.node[i] = htonl(u->node[i]);
305
306         trace_afs_make_vl_call(call);
307         return (struct afs_addr_list *)afs_make_call(&vc->ac, call, GFP_KERNEL, false);
308 }
309
310 /*
311  * Deliver reply data to an VL.GetCapabilities operation.
312  */
313 static int afs_deliver_vl_get_capabilities(struct afs_call *call)
314 {
315         u32 count;
316         int ret;
317
318         _enter("{%u,%zu/%u}",
319                call->unmarshall, iov_iter_count(call->_iter), call->count);
320
321         switch (call->unmarshall) {
322         case 0:
323                 afs_extract_to_tmp(call);
324                 call->unmarshall++;
325
326                 /* Extract the capabilities word count */
327         case 1:
328                 ret = afs_extract_data(call, true);
329                 if (ret < 0)
330                         return ret;
331
332                 count = ntohl(call->tmp);
333                 call->count = count;
334                 call->count2 = count;
335
336                 call->unmarshall++;
337                 afs_extract_discard(call, count * sizeof(__be32));
338
339                 /* Extract capabilities words */
340         case 2:
341                 ret = afs_extract_data(call, false);
342                 if (ret < 0)
343                         return ret;
344
345                 /* TODO: Examine capabilities */
346
347                 call->unmarshall++;
348                 break;
349         }
350
351         _leave(" = 0 [done]");
352         return 0;
353 }
354
355 static void afs_destroy_vl_get_capabilities(struct afs_call *call)
356 {
357         struct afs_vlserver *server = call->reply[0];
358
359         afs_put_vlserver(call->net, server);
360         afs_flat_call_destructor(call);
361 }
362
363 /*
364  * VL.GetCapabilities operation type
365  */
366 static const struct afs_call_type afs_RXVLGetCapabilities = {
367         .name           = "VL.GetCapabilities",
368         .op             = afs_VL_GetCapabilities,
369         .deliver        = afs_deliver_vl_get_capabilities,
370         .done           = afs_vlserver_probe_result,
371         .destructor     = afs_destroy_vl_get_capabilities,
372 };
373
374 /*
375  * Probe a volume server for the capabilities that it supports.  This can
376  * return up to 196 words.
377  *
378  * We use this to probe for service upgrade to determine what the server at the
379  * other end supports.
380  */
381 int afs_vl_get_capabilities(struct afs_net *net,
382                             struct afs_addr_cursor *ac,
383                             struct key *key,
384                             struct afs_vlserver *server,
385                             unsigned int server_index,
386                             bool async)
387 {
388         struct afs_call *call;
389         __be32 *bp;
390
391         _enter("");
392
393         call = afs_alloc_flat_call(net, &afs_RXVLGetCapabilities, 1 * 4, 16 * 4);
394         if (!call)
395                 return -ENOMEM;
396
397         call->key = key;
398         call->reply[0] = afs_get_vlserver(server);
399         call->reply[1] = (void *)(long)server_index;
400         call->upgrade = true;
401         call->want_reply_time = true;
402
403         /* marshall the parameters */
404         bp = call->request;
405         *bp++ = htonl(VLGETCAPABILITIES);
406
407         /* Can't take a ref on server */
408         trace_afs_make_vl_call(call);
409         return afs_make_call(ac, call, GFP_KERNEL, async);
410 }
411
412 /*
413  * Deliver reply data to a YFSVL.GetEndpoints call.
414  *
415  *      GetEndpoints(IN yfsServerAttributes *attr,
416  *                   OUT opr_uuid *uuid,
417  *                   OUT afs_int32 *uniquifier,
418  *                   OUT endpoints *fsEndpoints,
419  *                   OUT endpoints *volEndpoints)
420  */
421 static int afs_deliver_yfsvl_get_endpoints(struct afs_call *call)
422 {
423         struct afs_addr_list *alist;
424         __be32 *bp;
425         u32 uniquifier, size;
426         int ret;
427
428         _enter("{%u,%zu,%u}",
429                call->unmarshall, iov_iter_count(call->_iter), call->count2);
430
431         switch (call->unmarshall) {
432         case 0:
433                 afs_extract_to_buf(call, sizeof(uuid_t) + 3 * sizeof(__be32));
434                 call->unmarshall = 1;
435
436                 /* Extract the returned uuid, uniquifier, fsEndpoints count and
437                  * either the first fsEndpoint type or the volEndpoints
438                  * count if there are no fsEndpoints. */
439         case 1:
440                 ret = afs_extract_data(call, true);
441                 if (ret < 0)
442                         return ret;
443
444                 bp = call->buffer + sizeof(uuid_t);
445                 uniquifier      = ntohl(*bp++);
446                 call->count     = ntohl(*bp++);
447                 call->count2    = ntohl(*bp); /* Type or next count */
448
449                 if (call->count > YFS_MAXENDPOINTS)
450                         return afs_protocol_error(call, -EBADMSG,
451                                                   afs_eproto_yvl_fsendpt_num);
452
453                 alist = afs_alloc_addrlist(call->count, FS_SERVICE, AFS_FS_PORT);
454                 if (!alist)
455                         return -ENOMEM;
456                 alist->version = uniquifier;
457                 call->reply[0] = alist;
458
459                 if (call->count == 0)
460                         goto extract_volendpoints;
461
462         next_fsendpoint:
463                 switch (call->count2) {
464                 case YFS_ENDPOINT_IPV4:
465                         size = sizeof(__be32) * (1 + 1 + 1);
466                         break;
467                 case YFS_ENDPOINT_IPV6:
468                         size = sizeof(__be32) * (1 + 4 + 1);
469                         break;
470                 default:
471                         return afs_protocol_error(call, -EBADMSG,
472                                                   afs_eproto_yvl_fsendpt_type);
473                 }
474
475                 size += sizeof(__be32);
476                 afs_extract_to_buf(call, size);
477                 call->unmarshall = 2;
478
479                 /* Extract fsEndpoints[] entries */
480         case 2:
481                 ret = afs_extract_data(call, true);
482                 if (ret < 0)
483                         return ret;
484
485                 alist = call->reply[0];
486                 bp = call->buffer;
487                 switch (call->count2) {
488                 case YFS_ENDPOINT_IPV4:
489                         if (ntohl(bp[0]) != sizeof(__be32) * 2)
490                                 return afs_protocol_error(call, -EBADMSG,
491                                                           afs_eproto_yvl_fsendpt4_len);
492                         afs_merge_fs_addr4(alist, bp[1], ntohl(bp[2]));
493                         bp += 3;
494                         break;
495                 case YFS_ENDPOINT_IPV6:
496                         if (ntohl(bp[0]) != sizeof(__be32) * 5)
497                                 return afs_protocol_error(call, -EBADMSG,
498                                                           afs_eproto_yvl_fsendpt6_len);
499                         afs_merge_fs_addr6(alist, bp + 1, ntohl(bp[5]));
500                         bp += 6;
501                         break;
502                 default:
503                         return afs_protocol_error(call, -EBADMSG,
504                                                   afs_eproto_yvl_fsendpt_type);
505                 }
506
507                 /* Got either the type of the next entry or the count of
508                  * volEndpoints if no more fsEndpoints.
509                  */
510                 call->count2 = ntohl(*bp++);
511
512                 call->count--;
513                 if (call->count > 0)
514                         goto next_fsendpoint;
515
516         extract_volendpoints:
517                 /* Extract the list of volEndpoints. */
518                 call->count = call->count2;
519                 if (!call->count)
520                         goto end;
521                 if (call->count > YFS_MAXENDPOINTS)
522                         return afs_protocol_error(call, -EBADMSG,
523                                                   afs_eproto_yvl_vlendpt_type);
524
525                 afs_extract_to_buf(call, 1 * sizeof(__be32));
526                 call->unmarshall = 3;
527
528                 /* Extract the type of volEndpoints[0].  Normally we would
529                  * extract the type of the next endpoint when we extract the
530                  * data of the current one, but this is the first...
531                  */
532         case 3:
533                 ret = afs_extract_data(call, true);
534                 if (ret < 0)
535                         return ret;
536
537                 bp = call->buffer;
538
539         next_volendpoint:
540                 call->count2 = ntohl(*bp++);
541                 switch (call->count2) {
542                 case YFS_ENDPOINT_IPV4:
543                         size = sizeof(__be32) * (1 + 1 + 1);
544                         break;
545                 case YFS_ENDPOINT_IPV6:
546                         size = sizeof(__be32) * (1 + 4 + 1);
547                         break;
548                 default:
549                         return afs_protocol_error(call, -EBADMSG,
550                                                   afs_eproto_yvl_vlendpt_type);
551                 }
552
553                 if (call->count > 1)
554                         size += sizeof(__be32); /* Get next type too */
555                 afs_extract_to_buf(call, size);
556                 call->unmarshall = 4;
557
558                 /* Extract volEndpoints[] entries */
559         case 4:
560                 ret = afs_extract_data(call, true);
561                 if (ret < 0)
562                         return ret;
563
564                 bp = call->buffer;
565                 switch (call->count2) {
566                 case YFS_ENDPOINT_IPV4:
567                         if (ntohl(bp[0]) != sizeof(__be32) * 2)
568                                 return afs_protocol_error(call, -EBADMSG,
569                                                           afs_eproto_yvl_vlendpt4_len);
570                         bp += 3;
571                         break;
572                 case YFS_ENDPOINT_IPV6:
573                         if (ntohl(bp[0]) != sizeof(__be32) * 5)
574                                 return afs_protocol_error(call, -EBADMSG,
575                                                           afs_eproto_yvl_vlendpt6_len);
576                         bp += 6;
577                         break;
578                 default:
579                         return afs_protocol_error(call, -EBADMSG,
580                                                   afs_eproto_yvl_vlendpt_type);
581                 }
582
583                 /* Got either the type of the next entry or the count of
584                  * volEndpoints if no more fsEndpoints.
585                  */
586                 call->count--;
587                 if (call->count > 0)
588                         goto next_volendpoint;
589
590         end:
591                 afs_extract_discard(call, 0);
592                 call->unmarshall = 5;
593
594                 /* Done */
595         case 5:
596                 ret = afs_extract_data(call, false);
597                 if (ret < 0)
598                         return ret;
599                 call->unmarshall = 6;
600
601         case 6:
602                 break;
603         }
604
605         alist = call->reply[0];
606         _leave(" = 0 [done]");
607         return 0;
608 }
609
610 /*
611  * YFSVL.GetEndpoints operation type.
612  */
613 static const struct afs_call_type afs_YFSVLGetEndpoints = {
614         .name           = "YFSVL.GetEndpoints",
615         .op             = afs_YFSVL_GetEndpoints,
616         .deliver        = afs_deliver_yfsvl_get_endpoints,
617         .destructor     = afs_vl_get_addrs_u_destructor,
618 };
619
620 /*
621  * Dispatch an operation to get the addresses for a server, where the server is
622  * nominated by UUID.
623  */
624 struct afs_addr_list *afs_yfsvl_get_endpoints(struct afs_vl_cursor *vc,
625                                               const uuid_t *uuid)
626 {
627         struct afs_call *call;
628         struct afs_net *net = vc->cell->net;
629         __be32 *bp;
630
631         _enter("");
632
633         call = afs_alloc_flat_call(net, &afs_YFSVLGetEndpoints,
634                                    sizeof(__be32) * 2 + sizeof(*uuid),
635                                    sizeof(struct in6_addr) + sizeof(__be32) * 3);
636         if (!call)
637                 return ERR_PTR(-ENOMEM);
638
639         call->key = vc->key;
640         call->reply[0] = NULL;
641         call->ret_reply0 = true;
642
643         /* Marshall the parameters */
644         bp = call->request;
645         *bp++ = htonl(YVLGETENDPOINTS);
646         *bp++ = htonl(YFS_SERVER_UUID);
647         memcpy(bp, uuid, sizeof(*uuid)); /* Type opr_uuid */
648
649         trace_afs_make_vl_call(call);
650         return (struct afs_addr_list *)afs_make_call(&vc->ac, call, GFP_KERNEL, false);
651 }