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 "internal.h"
  16
  17 /*
  18  * map volume locator abort codes to error codes
  19  */
  20 static int afs_vl_abort_to_error(u32 abort_code)
  21 {
  22         _enter("%u", abort_code);
  23
  24         switch (abort_code) {
  25         case AFSVL_IDEXIST:             return -EEXIST;
  26         case AFSVL_IO:                  return -EREMOTEIO;
  27         case AFSVL_NAMEEXIST:           return -EEXIST;
  28         case AFSVL_CREATEFAIL:          return -EREMOTEIO;
  29         case AFSVL_NOENT:               return -ENOMEDIUM;
  30         case AFSVL_EMPTY:               return -ENOMEDIUM;
  31         case AFSVL_ENTDELETED:          return -ENOMEDIUM;
  32         case AFSVL_BADNAME:             return -EINVAL;
  33         case AFSVL_BADINDEX:            return -EINVAL;
  34         case AFSVL_BADVOLTYPE:          return -EINVAL;
  35         case AFSVL_BADSERVER:           return -EINVAL;
  36         case AFSVL_BADPARTITION:        return -EINVAL;
  37         case AFSVL_REPSFULL:            return -EFBIG;
  38         case AFSVL_NOREPSERVER:         return -ENOENT;
  39         case AFSVL_DUPREPSERVER:        return -EEXIST;
  40         case AFSVL_RWNOTFOUND:          return -ENOENT;
  41         case AFSVL_BADREFCOUNT:         return -EINVAL;
  42         case AFSVL_SIZEEXCEEDED:        return -EINVAL;
  43         case AFSVL_BADENTRY:            return -EINVAL;
  44         case AFSVL_BADVOLIDBUMP:        return -EINVAL;
  45         case AFSVL_IDALREADYHASHED:     return -EINVAL;
  46         case AFSVL_ENTRYLOCKED:         return -EBUSY;
  47         case AFSVL_BADVOLOPER:          return -EBADRQC;
  48         case AFSVL_BADRELLOCKTYPE:      return -EINVAL;
  49         case AFSVL_RERELEASE:           return -EREMOTEIO;
  50         case AFSVL_BADSERVERFLAG:       return -EINVAL;
  51         case AFSVL_PERM:                return -EACCES;
  52         case AFSVL_NOMEM:               return -EREMOTEIO;
  53         default:
  54                 return afs_abort_to_error(abort_code);
  55         }
  56 }
  57
  58 /*
  59  * deliver reply data to a VL.GetEntryByXXX call
  60  */
  61 static int afs_deliver_vl_get_entry_by_xxx(struct afs_call *call,
  62                                            struct sk_buff *skb, bool last)
  63 {
  64         struct afs_cache_vlocation *entry;
  65         __be32 *bp;
  66         u32 tmp;
  67         int loop;
  68
  69         _enter(",,%u", last);
  70
  71         afs_transfer_reply(call, skb);
  72         if (!last)
  73                 return 0;
  74
  75         if (call->reply_size != call->reply_max)
  76                 return -EBADMSG;
  77
  78         /* unmarshall the reply once we've received all of it */
  79         entry = call->reply;
  80         bp = call->buffer;
  81
  82         for (loop = 0; loop < 64; loop++)
  83                 entry->name[loop] = ntohl(*bp++);
  84         entry->name[loop] = 0;
  85         bp++; /* final NUL */
  86
  87         bp++; /* type */
  88         entry->nservers = ntohl(*bp++);
  89
  90         for (loop = 0; loop < 8; loop++)
  91                 entry->servers[loop].s_addr = *bp++;
  92
  93         bp += 8; /* partition IDs */
  94
  95         for (loop = 0; loop < 8; loop++) {
  96                 tmp = ntohl(*bp++);
  97                 entry->srvtmask[loop] = 0;
  98                 if (tmp & AFS_VLSF_RWVOL)
  99                         entry->srvtmask[loop] |= AFS_VOL_VTM_RW;
 100                 if (tmp & AFS_VLSF_ROVOL)
 101                         entry->srvtmask[loop] |= AFS_VOL_VTM_RO;
 102                 if (tmp & AFS_VLSF_BACKVOL)
 103                         entry->srvtmask[loop] |= AFS_VOL_VTM_BAK;
 104         }
 105
 106         entry->vid[0] = ntohl(*bp++);
 107         entry->vid[1] = ntohl(*bp++);
 108         entry->vid[2] = ntohl(*bp++);
 109
 110         bp++; /* clone ID */
 111
 112         tmp = ntohl(*bp++); /* flags */
 113         entry->vidmask = 0;
 114         if (tmp & AFS_VLF_RWEXISTS)
 115                 entry->vidmask |= AFS_VOL_VTM_RW;
 116         if (tmp & AFS_VLF_ROEXISTS)
 117                 entry->vidmask |= AFS_VOL_VTM_RO;
 118         if (tmp & AFS_VLF_BACKEXISTS)
 119                 entry->vidmask |= AFS_VOL_VTM_BAK;
 120         if (!entry->vidmask)
 121                 return -EBADMSG;
 122
 123         _leave(" = 0 [done]");
 124         return 0;
 125 }
 126
 127 /*
 128  * VL.GetEntryByName operation type
 129  */
 130 static const struct afs_call_type afs_RXVLGetEntryByName = {
 131         .name           = "VL.GetEntryByName",
 132         .deliver        = afs_deliver_vl_get_entry_by_xxx,
 133         .abort_to_error = afs_vl_abort_to_error,
 134         .destructor     = afs_flat_call_destructor,
 135 };
 136
 137 /*
 138  * VL.GetEntryById operation type
 139  */
 140 static const struct afs_call_type afs_RXVLGetEntryById = {
 141         .name           = "VL.GetEntryById",
 142         .deliver        = afs_deliver_vl_get_entry_by_xxx,
 143         .abort_to_error = afs_vl_abort_to_error,
 144         .destructor     = afs_flat_call_destructor,
 145 };
 146
 147 /*
 148  * dispatch a get volume entry by name operation
 149  */
 150 int afs_vl_get_entry_by_name(struct in_addr *addr,
 151                              struct key *key,
 152                              const char *volname,
 153                              struct afs_cache_vlocation *entry,
 154                              const struct afs_wait_mode *wait_mode)
 155 {
 156         struct afs_call *call;
 157         size_t volnamesz, reqsz, padsz;
 158         __be32 *bp;
 159
 160         _enter("");
 161
 162         volnamesz = strlen(volname);
 163         padsz = (4 - (volnamesz & 3)) & 3;
 164         reqsz = 8 + volnamesz + padsz;
 165
 166         call = afs_alloc_flat_call(&afs_RXVLGetEntryByName, reqsz, 384);
 167         if (!call)
 168                 return -ENOMEM;
 169
 170         call->key = key;
 171         call->reply = entry;
 172         call->service_id = VL_SERVICE;
 173         call->port = htons(AFS_VL_PORT);
 174
 175         /* marshall the parameters */
 176         bp = call->request;
 177         *bp++ = htonl(VLGETENTRYBYNAME);
 178         *bp++ = htonl(volnamesz);
 179         memcpy(bp, volname, volnamesz);
 180         if (padsz > 0)
 181                 memset((void *) bp + volnamesz, 0, padsz);
 182
 183         /* initiate the call */
 184         return afs_make_call(addr, call, GFP_KERNEL, wait_mode);
 185 }
 186
 187 /*
 188  * dispatch a get volume entry by ID operation
 189  */
 190 int afs_vl_get_entry_by_id(struct in_addr *addr,
 191                            struct key *key,
 192                            afs_volid_t volid,
 193                            afs_voltype_t voltype,
 194                            struct afs_cache_vlocation *entry,
 195                            const struct afs_wait_mode *wait_mode)
 196 {
 197         struct afs_call *call;
 198         __be32 *bp;
 199
 200         _enter("");
 201
 202         call = afs_alloc_flat_call(&afs_RXVLGetEntryById, 12, 384);
 203         if (!call)
 204                 return -ENOMEM;
 205
 206         call->key = key;
 207         call->reply = entry;
 208         call->service_id = VL_SERVICE;
 209         call->port = htons(AFS_VL_PORT);
 210
 211         /* marshall the parameters */
 212         bp = call->request;
 213         *bp++ = htonl(VLGETENTRYBYID);
 214         *bp++ = htonl(volid);
 215         *bp   = htonl(voltype);
 216
 217         /* initiate the call */
 218         return afs_make_call(addr, call, GFP_KERNEL, wait_mode);
 219 }