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
nfsd4_ff_proc_layoutget(struct inode * inode,const struct svc_fh * fhp,struct nfsd4_layoutget * args)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
nfsd4_ff_proc_getdeviceinfo(struct super_block * sb,struct svc_rqst * rqstp,struct nfs4_client * clp,struct nfsd4_getdeviceinfo * gdp)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