fs/nfsd/flexfilelayout.c

   1 // SPDX-License-Identifier: GPL-2.0
   2 /*
   3  * Copyright (c) 2016 Tom Haynes <loghyr@primarydata.com>
   4  *
   5  * The following implements a super-simple flex-file server
   6  * where the NFSv4.1 mds is also the ds. And the storage is
   7  * the same. I.e., writing to the mds via a NFSv4.1 WRITE
   8  * goes to the same location as the NFSv3 WRITE.
   9  */
  10 #include <linux/slab.h>
  11
  12 #include <linux/nfsd/debug.h>
  13
  14 #include <linux/sunrpc/addr.h>
  15
  16 #include "flexfilelayoutxdr.h"
  17 #include "pnfs.h"
  18 #include "vfs.h"
  19
  20 #define NFSDDBG_FACILITY        NFSDDBG_PNFS
  21
  22 static __be32
  23 nfsd4_ff_proc_layoutget(struct inode *inode, const struct svc_fh *fhp,
  24                 struct nfsd4_layoutget *args)
  25 {
  26         struct nfsd4_layout_seg *seg = &args->lg_seg;
  27         u32 device_generation = 0;
  28         int error;
  29         uid_t u;
  30
  31         struct pnfs_ff_layout *fl;
  32
  33         /*
  34          * The super simple flex file server has 1 mirror, 1 data server,
  35          * and 1 file handle. So instead of 4 allocs, do 1 for now.
  36          * Zero it out for the stateid - don't want junk in there!
  37          */
  38         error = -ENOMEM;
  39         fl = kzalloc(sizeof(*fl), GFP_KERNEL);
  40         if (!fl)
  41                 goto out_error;
  42         args->lg_content = fl;
  43
  44         /*
  45          * Avoid layout commit, try to force the I/O to the DS,
  46          * and for fun, cause all IOMODE_RW layout segments to
  47          * effectively be WRITE only.
  48          */
  49         fl->flags = FF_FLAGS_NO_LAYOUTCOMMIT | FF_FLAGS_NO_IO_THRU_MDS |
  50                     FF_FLAGS_NO_READ_IO;
  51
  52         /* Do not allow a IOMODE_READ segment to have write pemissions */
  53         if (seg->iomode == IOMODE_READ) {
  54                 u = from_kuid(&init_user_ns, inode->i_uid) + 1;
  55                 fl->uid = make_kuid(&init_user_ns, u);
  56         } else
  57                 fl->uid = inode->i_uid;
  58         fl->gid = inode->i_gid;
  59
  60         error = nfsd4_set_deviceid(&fl->deviceid, fhp, device_generation);
  61         if (error)
  62                 goto out_error;
  63
  64         fl->fh.size = fhp->fh_handle.fh_size;
  65         memcpy(fl->fh.data, &fhp->fh_handle.fh_raw, fl->fh.size);
  66
  67         /* Give whole file layout segments */
  68         seg->offset = 0;
  69         seg->length = NFS4_MAX_UINT64;
  70
  71         dprintk("GET: 0x%llx:0x%llx %d\n", seg->offset, seg->length,
  72                 seg->iomode);
  73         return 0;
  74
  75 out_error:
  76         seg->length = 0;
  77         return nfserrno(error);
  78 }
  79
  80 static __be32
  81 nfsd4_ff_proc_getdeviceinfo(struct super_block *sb, struct svc_rqst *rqstp,
  82                 struct nfs4_client *clp, struct nfsd4_getdeviceinfo *gdp)
  83 {
  84         struct pnfs_ff_device_addr *da;
  85
  86         u16 port;
  87         char addr[INET6_ADDRSTRLEN];
  88
  89         da = kzalloc(sizeof(struct pnfs_ff_device_addr), GFP_KERNEL);
  90         if (!da)
  91                 return nfserrno(-ENOMEM);
  92
  93         gdp->gd_device = da;
  94
  95         da->version = 3;
  96         da->minor_version = 0;
  97
  98         da->rsize = svc_max_payload(rqstp);
  99         da->wsize = da->rsize;
 100
 101         rpc_ntop((struct sockaddr *)&rqstp->rq_daddr,
 102                  addr, INET6_ADDRSTRLEN);
 103         if (rqstp->rq_daddr.ss_family == AF_INET) {
 104                 struct sockaddr_in *sin;
 105
 106                 sin = (struct sockaddr_in *)&rqstp->rq_daddr;
 107                 port = ntohs(sin->sin_port);
 108                 snprintf(da->netaddr.netid, FF_NETID_LEN + 1, "tcp");
 109                 da->netaddr.netid_len = 3;
 110         } else {
 111                 struct sockaddr_in6 *sin6;
 112
 113                 sin6 = (struct sockaddr_in6 *)&rqstp->rq_daddr;
 114                 port = ntohs(sin6->sin6_port);
 115                 snprintf(da->netaddr.netid, FF_NETID_LEN + 1, "tcp6");
 116                 da->netaddr.netid_len = 4;
 117         }
 118
 119         da->netaddr.addr_len =
 120                 snprintf(da->netaddr.addr, FF_ADDR_LEN + 1,
 121                          "%s.%d.%d", addr, port >> 8, port & 0xff);
 122
 123         da->tightly_coupled = false;
 124
 125         return 0;
 126 }
 127
 128 const struct nfsd4_layout_ops ff_layout_ops = {
 129         .notify_types           =
 130                         NOTIFY_DEVICEID4_DELETE | NOTIFY_DEVICEID4_CHANGE,
 131         .disable_recalls        = true,
 132         .proc_getdeviceinfo     = nfsd4_ff_proc_getdeviceinfo,
 133         .encode_getdeviceinfo   = nfsd4_ff_encode_getdeviceinfo,
 134         .proc_layoutget         = nfsd4_ff_proc_layoutget,
 135         .encode_layoutget       = nfsd4_ff_encode_layoutget,
 136 };