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 };
137
Linux® is a registered trademark of Linus Torvalds in the United States and other countries.
TOMOYO® is a registered trademark of NTT DATA CORPORATION.