Linux Audio

Check our new training course

Loading...
v3.1
 
  1/*
  2 * linux/fs/lockd/xdr4.c
  3 *
  4 * XDR support for lockd and the lock client.
  5 *
  6 * Copyright (C) 1995, 1996 Olaf Kirch <okir@monad.swb.de>
  7 * Copyright (C) 1999, Trond Myklebust <trond.myklebust@fys.uio.no>
  8 */
  9
 10#include <linux/types.h>
 11#include <linux/sched.h>
 12#include <linux/nfs.h>
 13
 14#include <linux/sunrpc/xdr.h>
 15#include <linux/sunrpc/clnt.h>
 16#include <linux/sunrpc/svc.h>
 17#include <linux/sunrpc/stats.h>
 18#include <linux/lockd/lockd.h>
 19
 20#define NLMDBG_FACILITY		NLMDBG_XDR
 21
 22static inline loff_t
 23s64_to_loff_t(__s64 offset)
 24{
 25	return (loff_t)offset;
 26}
 27
 28
 29static inline s64
 30loff_t_to_s64(loff_t offset)
 31{
 32	s64 res;
 33	if (offset > NLM4_OFFSET_MAX)
 34		res = NLM4_OFFSET_MAX;
 35	else if (offset < -NLM4_OFFSET_MAX)
 36		res = -NLM4_OFFSET_MAX;
 37	else
 38		res = offset;
 39	return res;
 40}
 41
 42/*
 43 * XDR functions for basic NLM types
 44 */
 45static __be32 *
 46nlm4_decode_cookie(__be32 *p, struct nlm_cookie *c)
 47{
 48	unsigned int	len;
 49
 50	len = ntohl(*p++);
 51	
 52	if(len==0)
 53	{
 54		c->len=4;
 55		memset(c->data, 0, 4);	/* hockeypux brain damage */
 56	}
 57	else if(len<=NLM_MAXCOOKIELEN)
 58	{
 59		c->len=len;
 60		memcpy(c->data, p, len);
 61		p+=XDR_QUADLEN(len);
 62	}
 63	else 
 64	{
 65		dprintk("lockd: bad cookie size %d (only cookies under "
 66			"%d bytes are supported.)\n",
 67				len, NLM_MAXCOOKIELEN);
 68		return NULL;
 69	}
 70	return p;
 71}
 72
 73static __be32 *
 74nlm4_encode_cookie(__be32 *p, struct nlm_cookie *c)
 75{
 76	*p++ = htonl(c->len);
 77	memcpy(p, c->data, c->len);
 78	p+=XDR_QUADLEN(c->len);
 79	return p;
 80}
 81
 82static __be32 *
 83nlm4_decode_fh(__be32 *p, struct nfs_fh *f)
 84{
 85	memset(f->data, 0, sizeof(f->data));
 86	f->size = ntohl(*p++);
 87	if (f->size > NFS_MAXFHSIZE) {
 88		dprintk("lockd: bad fhandle size %d (should be <=%d)\n",
 89			f->size, NFS_MAXFHSIZE);
 90		return NULL;
 91	}
 92      	memcpy(f->data, p, f->size);
 93	return p + XDR_QUADLEN(f->size);
 94}
 95
 96/*
 97 * Encode and decode owner handle
 98 */
 99static __be32 *
100nlm4_decode_oh(__be32 *p, struct xdr_netobj *oh)
101{
102	return xdr_decode_netobj(p, oh);
103}
104
105static __be32 *
106nlm4_decode_lock(__be32 *p, struct nlm_lock *lock)
107{
108	struct file_lock	*fl = &lock->fl;
109	__u64			len, start;
110	__s64			end;
111
112	if (!(p = xdr_decode_string_inplace(p, &lock->caller,
113					    &lock->len, NLM_MAXSTRLEN))
114	 || !(p = nlm4_decode_fh(p, &lock->fh))
115	 || !(p = nlm4_decode_oh(p, &lock->oh)))
116		return NULL;
117	lock->svid  = ntohl(*p++);
118
119	locks_init_lock(fl);
120	fl->fl_owner = current->files;
121	fl->fl_pid   = (pid_t)lock->svid;
122	fl->fl_flags = FL_POSIX;
123	fl->fl_type  = F_RDLCK;		/* as good as anything else */
124	p = xdr_decode_hyper(p, &start);
125	p = xdr_decode_hyper(p, &len);
126	end = start + len - 1;
127
128	fl->fl_start = s64_to_loff_t(start);
129
130	if (len == 0 || end < 0)
131		fl->fl_end = OFFSET_MAX;
132	else
133		fl->fl_end = s64_to_loff_t(end);
134	return p;
135}
136
137/*
138 * Encode result of a TEST/TEST_MSG call
139 */
140static __be32 *
141nlm4_encode_testres(__be32 *p, struct nlm_res *resp)
142{
143	s64		start, len;
144
145	dprintk("xdr: before encode_testres (p %p resp %p)\n", p, resp);
146	if (!(p = nlm4_encode_cookie(p, &resp->cookie)))
147		return NULL;
148	*p++ = resp->status;
149
150	if (resp->status == nlm_lck_denied) {
151		struct file_lock	*fl = &resp->lock.fl;
152
153		*p++ = (fl->fl_type == F_RDLCK)? xdr_zero : xdr_one;
154		*p++ = htonl(resp->lock.svid);
155
156		/* Encode owner handle. */
157		if (!(p = xdr_encode_netobj(p, &resp->lock.oh)))
158			return NULL;
159
160		start = loff_t_to_s64(fl->fl_start);
161		if (fl->fl_end == OFFSET_MAX)
162			len = 0;
163		else
164			len = loff_t_to_s64(fl->fl_end - fl->fl_start + 1);
165		
166		p = xdr_encode_hyper(p, start);
167		p = xdr_encode_hyper(p, len);
168		dprintk("xdr: encode_testres (status %u pid %d type %d start %Ld end %Ld)\n",
169			resp->status, (int)resp->lock.svid, fl->fl_type,
170			(long long)fl->fl_start,  (long long)fl->fl_end);
171	}
172
173	dprintk("xdr: after encode_testres (p %p resp %p)\n", p, resp);
174	return p;
175}
176
177
178/*
179 * First, the server side XDR functions
180 */
181int
182nlm4svc_decode_testargs(struct svc_rqst *rqstp, __be32 *p, nlm_args *argp)
183{
 
184	u32	exclusive;
185
186	if (!(p = nlm4_decode_cookie(p, &argp->cookie)))
187		return 0;
188
189	exclusive = ntohl(*p++);
190	if (!(p = nlm4_decode_lock(p, &argp->lock)))
191		return 0;
192	if (exclusive)
193		argp->lock.fl.fl_type = F_WRLCK;
194
195	return xdr_argsize_check(rqstp, p);
196}
197
198int
199nlm4svc_encode_testres(struct svc_rqst *rqstp, __be32 *p, struct nlm_res *resp)
200{
 
 
201	if (!(p = nlm4_encode_testres(p, resp)))
202		return 0;
203	return xdr_ressize_check(rqstp, p);
204}
205
206int
207nlm4svc_decode_lockargs(struct svc_rqst *rqstp, __be32 *p, nlm_args *argp)
208{
 
209	u32	exclusive;
210
211	if (!(p = nlm4_decode_cookie(p, &argp->cookie)))
212		return 0;
213	argp->block  = ntohl(*p++);
214	exclusive    = ntohl(*p++);
215	if (!(p = nlm4_decode_lock(p, &argp->lock)))
216		return 0;
217	if (exclusive)
218		argp->lock.fl.fl_type = F_WRLCK;
219	argp->reclaim = ntohl(*p++);
220	argp->state   = ntohl(*p++);
221	argp->monitor = 1;		/* monitor client by default */
222
223	return xdr_argsize_check(rqstp, p);
224}
225
226int
227nlm4svc_decode_cancargs(struct svc_rqst *rqstp, __be32 *p, nlm_args *argp)
228{
 
229	u32	exclusive;
230
231	if (!(p = nlm4_decode_cookie(p, &argp->cookie)))
232		return 0;
233	argp->block = ntohl(*p++);
234	exclusive = ntohl(*p++);
235	if (!(p = nlm4_decode_lock(p, &argp->lock)))
236		return 0;
237	if (exclusive)
238		argp->lock.fl.fl_type = F_WRLCK;
239	return xdr_argsize_check(rqstp, p);
240}
241
242int
243nlm4svc_decode_unlockargs(struct svc_rqst *rqstp, __be32 *p, nlm_args *argp)
244{
 
 
245	if (!(p = nlm4_decode_cookie(p, &argp->cookie))
246	 || !(p = nlm4_decode_lock(p, &argp->lock)))
247		return 0;
248	argp->lock.fl.fl_type = F_UNLCK;
249	return xdr_argsize_check(rqstp, p);
250}
251
252int
253nlm4svc_decode_shareargs(struct svc_rqst *rqstp, __be32 *p, nlm_args *argp)
254{
 
255	struct nlm_lock	*lock = &argp->lock;
256
257	memset(lock, 0, sizeof(*lock));
258	locks_init_lock(&lock->fl);
259	lock->svid = ~(u32) 0;
260	lock->fl.fl_pid = (pid_t)lock->svid;
261
262	if (!(p = nlm4_decode_cookie(p, &argp->cookie))
263	 || !(p = xdr_decode_string_inplace(p, &lock->caller,
264					    &lock->len, NLM_MAXSTRLEN))
265	 || !(p = nlm4_decode_fh(p, &lock->fh))
266	 || !(p = nlm4_decode_oh(p, &lock->oh)))
267		return 0;
268	argp->fsm_mode = ntohl(*p++);
269	argp->fsm_access = ntohl(*p++);
270	return xdr_argsize_check(rqstp, p);
271}
272
273int
274nlm4svc_encode_shareres(struct svc_rqst *rqstp, __be32 *p, struct nlm_res *resp)
275{
 
 
276	if (!(p = nlm4_encode_cookie(p, &resp->cookie)))
277		return 0;
278	*p++ = resp->status;
279	*p++ = xdr_zero;		/* sequence argument */
280	return xdr_ressize_check(rqstp, p);
281}
282
283int
284nlm4svc_encode_res(struct svc_rqst *rqstp, __be32 *p, struct nlm_res *resp)
285{
 
 
286	if (!(p = nlm4_encode_cookie(p, &resp->cookie)))
287		return 0;
288	*p++ = resp->status;
289	return xdr_ressize_check(rqstp, p);
290}
291
292int
293nlm4svc_decode_notify(struct svc_rqst *rqstp, __be32 *p, struct nlm_args *argp)
294{
 
295	struct nlm_lock	*lock = &argp->lock;
296
297	if (!(p = xdr_decode_string_inplace(p, &lock->caller,
298					    &lock->len, NLM_MAXSTRLEN)))
299		return 0;
300	argp->state = ntohl(*p++);
301	return xdr_argsize_check(rqstp, p);
302}
303
304int
305nlm4svc_decode_reboot(struct svc_rqst *rqstp, __be32 *p, struct nlm_reboot *argp)
306{
 
 
307	if (!(p = xdr_decode_string_inplace(p, &argp->mon, &argp->len, SM_MAXSTRLEN)))
308		return 0;
309	argp->state = ntohl(*p++);
310	memcpy(&argp->priv.data, p, sizeof(argp->priv.data));
311	p += XDR_QUADLEN(SM_PRIV_SIZE);
312	return xdr_argsize_check(rqstp, p);
313}
314
315int
316nlm4svc_decode_res(struct svc_rqst *rqstp, __be32 *p, struct nlm_res *resp)
317{
 
 
318	if (!(p = nlm4_decode_cookie(p, &resp->cookie)))
319		return 0;
320	resp->status = *p++;
321	return xdr_argsize_check(rqstp, p);
322}
323
324int
325nlm4svc_decode_void(struct svc_rqst *rqstp, __be32 *p, void *dummy)
326{
327	return xdr_argsize_check(rqstp, p);
328}
329
330int
331nlm4svc_encode_void(struct svc_rqst *rqstp, __be32 *p, void *dummy)
332{
333	return xdr_ressize_check(rqstp, p);
334}
v4.17
  1// SPDX-License-Identifier: GPL-2.0
  2/*
  3 * linux/fs/lockd/xdr4.c
  4 *
  5 * XDR support for lockd and the lock client.
  6 *
  7 * Copyright (C) 1995, 1996 Olaf Kirch <okir@monad.swb.de>
  8 * Copyright (C) 1999, Trond Myklebust <trond.myklebust@fys.uio.no>
  9 */
 10
 11#include <linux/types.h>
 12#include <linux/sched.h>
 13#include <linux/nfs.h>
 14
 15#include <linux/sunrpc/xdr.h>
 16#include <linux/sunrpc/clnt.h>
 17#include <linux/sunrpc/svc.h>
 18#include <linux/sunrpc/stats.h>
 19#include <linux/lockd/lockd.h>
 20
 21#define NLMDBG_FACILITY		NLMDBG_XDR
 22
 23static inline loff_t
 24s64_to_loff_t(__s64 offset)
 25{
 26	return (loff_t)offset;
 27}
 28
 29
 30static inline s64
 31loff_t_to_s64(loff_t offset)
 32{
 33	s64 res;
 34	if (offset > NLM4_OFFSET_MAX)
 35		res = NLM4_OFFSET_MAX;
 36	else if (offset < -NLM4_OFFSET_MAX)
 37		res = -NLM4_OFFSET_MAX;
 38	else
 39		res = offset;
 40	return res;
 41}
 42
 43/*
 44 * XDR functions for basic NLM types
 45 */
 46static __be32 *
 47nlm4_decode_cookie(__be32 *p, struct nlm_cookie *c)
 48{
 49	unsigned int	len;
 50
 51	len = ntohl(*p++);
 52	
 53	if(len==0)
 54	{
 55		c->len=4;
 56		memset(c->data, 0, 4);	/* hockeypux brain damage */
 57	}
 58	else if(len<=NLM_MAXCOOKIELEN)
 59	{
 60		c->len=len;
 61		memcpy(c->data, p, len);
 62		p+=XDR_QUADLEN(len);
 63	}
 64	else 
 65	{
 66		dprintk("lockd: bad cookie size %d (only cookies under "
 67			"%d bytes are supported.)\n",
 68				len, NLM_MAXCOOKIELEN);
 69		return NULL;
 70	}
 71	return p;
 72}
 73
 74static __be32 *
 75nlm4_encode_cookie(__be32 *p, struct nlm_cookie *c)
 76{
 77	*p++ = htonl(c->len);
 78	memcpy(p, c->data, c->len);
 79	p+=XDR_QUADLEN(c->len);
 80	return p;
 81}
 82
 83static __be32 *
 84nlm4_decode_fh(__be32 *p, struct nfs_fh *f)
 85{
 86	memset(f->data, 0, sizeof(f->data));
 87	f->size = ntohl(*p++);
 88	if (f->size > NFS_MAXFHSIZE) {
 89		dprintk("lockd: bad fhandle size %d (should be <=%d)\n",
 90			f->size, NFS_MAXFHSIZE);
 91		return NULL;
 92	}
 93      	memcpy(f->data, p, f->size);
 94	return p + XDR_QUADLEN(f->size);
 95}
 96
 97/*
 98 * Encode and decode owner handle
 99 */
100static __be32 *
101nlm4_decode_oh(__be32 *p, struct xdr_netobj *oh)
102{
103	return xdr_decode_netobj(p, oh);
104}
105
106static __be32 *
107nlm4_decode_lock(__be32 *p, struct nlm_lock *lock)
108{
109	struct file_lock	*fl = &lock->fl;
110	__u64			len, start;
111	__s64			end;
112
113	if (!(p = xdr_decode_string_inplace(p, &lock->caller,
114					    &lock->len, NLM_MAXSTRLEN))
115	 || !(p = nlm4_decode_fh(p, &lock->fh))
116	 || !(p = nlm4_decode_oh(p, &lock->oh)))
117		return NULL;
118	lock->svid  = ntohl(*p++);
119
120	locks_init_lock(fl);
121	fl->fl_owner = current->files;
122	fl->fl_pid   = (pid_t)lock->svid;
123	fl->fl_flags = FL_POSIX;
124	fl->fl_type  = F_RDLCK;		/* as good as anything else */
125	p = xdr_decode_hyper(p, &start);
126	p = xdr_decode_hyper(p, &len);
127	end = start + len - 1;
128
129	fl->fl_start = s64_to_loff_t(start);
130
131	if (len == 0 || end < 0)
132		fl->fl_end = OFFSET_MAX;
133	else
134		fl->fl_end = s64_to_loff_t(end);
135	return p;
136}
137
138/*
139 * Encode result of a TEST/TEST_MSG call
140 */
141static __be32 *
142nlm4_encode_testres(__be32 *p, struct nlm_res *resp)
143{
144	s64		start, len;
145
146	dprintk("xdr: before encode_testres (p %p resp %p)\n", p, resp);
147	if (!(p = nlm4_encode_cookie(p, &resp->cookie)))
148		return NULL;
149	*p++ = resp->status;
150
151	if (resp->status == nlm_lck_denied) {
152		struct file_lock	*fl = &resp->lock.fl;
153
154		*p++ = (fl->fl_type == F_RDLCK)? xdr_zero : xdr_one;
155		*p++ = htonl(resp->lock.svid);
156
157		/* Encode owner handle. */
158		if (!(p = xdr_encode_netobj(p, &resp->lock.oh)))
159			return NULL;
160
161		start = loff_t_to_s64(fl->fl_start);
162		if (fl->fl_end == OFFSET_MAX)
163			len = 0;
164		else
165			len = loff_t_to_s64(fl->fl_end - fl->fl_start + 1);
166		
167		p = xdr_encode_hyper(p, start);
168		p = xdr_encode_hyper(p, len);
169		dprintk("xdr: encode_testres (status %u pid %d type %d start %Ld end %Ld)\n",
170			resp->status, (int)resp->lock.svid, fl->fl_type,
171			(long long)fl->fl_start,  (long long)fl->fl_end);
172	}
173
174	dprintk("xdr: after encode_testres (p %p resp %p)\n", p, resp);
175	return p;
176}
177
178
179/*
180 * First, the server side XDR functions
181 */
182int
183nlm4svc_decode_testargs(struct svc_rqst *rqstp, __be32 *p)
184{
185	struct nlm_args *argp = rqstp->rq_argp;
186	u32	exclusive;
187
188	if (!(p = nlm4_decode_cookie(p, &argp->cookie)))
189		return 0;
190
191	exclusive = ntohl(*p++);
192	if (!(p = nlm4_decode_lock(p, &argp->lock)))
193		return 0;
194	if (exclusive)
195		argp->lock.fl.fl_type = F_WRLCK;
196
197	return xdr_argsize_check(rqstp, p);
198}
199
200int
201nlm4svc_encode_testres(struct svc_rqst *rqstp, __be32 *p)
202{
203	struct nlm_res *resp = rqstp->rq_resp;
204
205	if (!(p = nlm4_encode_testres(p, resp)))
206		return 0;
207	return xdr_ressize_check(rqstp, p);
208}
209
210int
211nlm4svc_decode_lockargs(struct svc_rqst *rqstp, __be32 *p)
212{
213	struct nlm_args *argp = rqstp->rq_argp;
214	u32	exclusive;
215
216	if (!(p = nlm4_decode_cookie(p, &argp->cookie)))
217		return 0;
218	argp->block  = ntohl(*p++);
219	exclusive    = ntohl(*p++);
220	if (!(p = nlm4_decode_lock(p, &argp->lock)))
221		return 0;
222	if (exclusive)
223		argp->lock.fl.fl_type = F_WRLCK;
224	argp->reclaim = ntohl(*p++);
225	argp->state   = ntohl(*p++);
226	argp->monitor = 1;		/* monitor client by default */
227
228	return xdr_argsize_check(rqstp, p);
229}
230
231int
232nlm4svc_decode_cancargs(struct svc_rqst *rqstp, __be32 *p)
233{
234	struct nlm_args *argp = rqstp->rq_argp;
235	u32	exclusive;
236
237	if (!(p = nlm4_decode_cookie(p, &argp->cookie)))
238		return 0;
239	argp->block = ntohl(*p++);
240	exclusive = ntohl(*p++);
241	if (!(p = nlm4_decode_lock(p, &argp->lock)))
242		return 0;
243	if (exclusive)
244		argp->lock.fl.fl_type = F_WRLCK;
245	return xdr_argsize_check(rqstp, p);
246}
247
248int
249nlm4svc_decode_unlockargs(struct svc_rqst *rqstp, __be32 *p)
250{
251	struct nlm_args *argp = rqstp->rq_argp;
252
253	if (!(p = nlm4_decode_cookie(p, &argp->cookie))
254	 || !(p = nlm4_decode_lock(p, &argp->lock)))
255		return 0;
256	argp->lock.fl.fl_type = F_UNLCK;
257	return xdr_argsize_check(rqstp, p);
258}
259
260int
261nlm4svc_decode_shareargs(struct svc_rqst *rqstp, __be32 *p)
262{
263	struct nlm_args *argp = rqstp->rq_argp;
264	struct nlm_lock	*lock = &argp->lock;
265
266	memset(lock, 0, sizeof(*lock));
267	locks_init_lock(&lock->fl);
268	lock->svid = ~(u32) 0;
269	lock->fl.fl_pid = (pid_t)lock->svid;
270
271	if (!(p = nlm4_decode_cookie(p, &argp->cookie))
272	 || !(p = xdr_decode_string_inplace(p, &lock->caller,
273					    &lock->len, NLM_MAXSTRLEN))
274	 || !(p = nlm4_decode_fh(p, &lock->fh))
275	 || !(p = nlm4_decode_oh(p, &lock->oh)))
276		return 0;
277	argp->fsm_mode = ntohl(*p++);
278	argp->fsm_access = ntohl(*p++);
279	return xdr_argsize_check(rqstp, p);
280}
281
282int
283nlm4svc_encode_shareres(struct svc_rqst *rqstp, __be32 *p)
284{
285	struct nlm_res *resp = rqstp->rq_resp;
286
287	if (!(p = nlm4_encode_cookie(p, &resp->cookie)))
288		return 0;
289	*p++ = resp->status;
290	*p++ = xdr_zero;		/* sequence argument */
291	return xdr_ressize_check(rqstp, p);
292}
293
294int
295nlm4svc_encode_res(struct svc_rqst *rqstp, __be32 *p)
296{
297	struct nlm_res *resp = rqstp->rq_resp;
298
299	if (!(p = nlm4_encode_cookie(p, &resp->cookie)))
300		return 0;
301	*p++ = resp->status;
302	return xdr_ressize_check(rqstp, p);
303}
304
305int
306nlm4svc_decode_notify(struct svc_rqst *rqstp, __be32 *p)
307{
308	struct nlm_args *argp = rqstp->rq_argp;
309	struct nlm_lock	*lock = &argp->lock;
310
311	if (!(p = xdr_decode_string_inplace(p, &lock->caller,
312					    &lock->len, NLM_MAXSTRLEN)))
313		return 0;
314	argp->state = ntohl(*p++);
315	return xdr_argsize_check(rqstp, p);
316}
317
318int
319nlm4svc_decode_reboot(struct svc_rqst *rqstp, __be32 *p)
320{
321	struct nlm_reboot *argp = rqstp->rq_argp;
322
323	if (!(p = xdr_decode_string_inplace(p, &argp->mon, &argp->len, SM_MAXSTRLEN)))
324		return 0;
325	argp->state = ntohl(*p++);
326	memcpy(&argp->priv.data, p, sizeof(argp->priv.data));
327	p += XDR_QUADLEN(SM_PRIV_SIZE);
328	return xdr_argsize_check(rqstp, p);
329}
330
331int
332nlm4svc_decode_res(struct svc_rqst *rqstp, __be32 *p)
333{
334	struct nlm_res *resp = rqstp->rq_argp;
335
336	if (!(p = nlm4_decode_cookie(p, &resp->cookie)))
337		return 0;
338	resp->status = *p++;
339	return xdr_argsize_check(rqstp, p);
340}
341
342int
343nlm4svc_decode_void(struct svc_rqst *rqstp, __be32 *p)
344{
345	return xdr_argsize_check(rqstp, p);
346}
347
348int
349nlm4svc_encode_void(struct svc_rqst *rqstp, __be32 *p)
350{
351	return xdr_ressize_check(rqstp, p);
352}