Loading...
1/*
2 * net/9p/protocol.c
3 *
4 * 9P Protocol Support Code
5 *
6 * Copyright (C) 2008 by Eric Van Hensbergen <ericvh@gmail.com>
7 *
8 * Base on code from Anthony Liguori <aliguori@us.ibm.com>
9 * Copyright (C) 2008 by IBM, Corp.
10 *
11 * This program is free software; you can redistribute it and/or modify
12 * it under the terms of the GNU General Public License version 2
13 * as published by the Free Software Foundation.
14 *
15 * This program is distributed in the hope that it will be useful,
16 * but WITHOUT ANY WARRANTY; without even the implied warranty of
17 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
18 * GNU General Public License for more details.
19 *
20 * You should have received a copy of the GNU General Public License
21 * along with this program; if not, write to:
22 * Free Software Foundation
23 * 51 Franklin Street, Fifth Floor
24 * Boston, MA 02111-1301 USA
25 *
26 */
27
28#include <linux/module.h>
29#include <linux/errno.h>
30#include <linux/kernel.h>
31#include <linux/uaccess.h>
32#include <linux/slab.h>
33#include <linux/sched.h>
34#include <linux/stddef.h>
35#include <linux/types.h>
36#include <linux/uio.h>
37#include <net/9p/9p.h>
38#include <net/9p/client.h>
39#include "protocol.h"
40
41#include <trace/events/9p.h>
42
43static int
44p9pdu_writef(struct p9_fcall *pdu, int proto_version, const char *fmt, ...);
45
46void p9stat_free(struct p9_wstat *stbuf)
47{
48 kfree(stbuf->name);
49 kfree(stbuf->uid);
50 kfree(stbuf->gid);
51 kfree(stbuf->muid);
52 kfree(stbuf->extension);
53}
54EXPORT_SYMBOL(p9stat_free);
55
56size_t pdu_read(struct p9_fcall *pdu, void *data, size_t size)
57{
58 size_t len = min(pdu->size - pdu->offset, size);
59 memcpy(data, &pdu->sdata[pdu->offset], len);
60 pdu->offset += len;
61 return size - len;
62}
63
64static size_t pdu_write(struct p9_fcall *pdu, const void *data, size_t size)
65{
66 size_t len = min(pdu->capacity - pdu->size, size);
67 memcpy(&pdu->sdata[pdu->size], data, len);
68 pdu->size += len;
69 return size - len;
70}
71
72static size_t
73pdu_write_u(struct p9_fcall *pdu, struct iov_iter *from, size_t size)
74{
75 size_t len = min(pdu->capacity - pdu->size, size);
76 struct iov_iter i = *from;
77 if (copy_from_iter(&pdu->sdata[pdu->size], len, &i) != len)
78 len = 0;
79
80 pdu->size += len;
81 return size - len;
82}
83
84/*
85 b - int8_t
86 w - int16_t
87 d - int32_t
88 q - int64_t
89 s - string
90 u - numeric uid
91 g - numeric gid
92 S - stat
93 Q - qid
94 D - data blob (int32_t size followed by void *, results are not freed)
95 T - array of strings (int16_t count, followed by strings)
96 R - array of qids (int16_t count, followed by qids)
97 A - stat for 9p2000.L (p9_stat_dotl)
98 ? - if optional = 1, continue parsing
99*/
100
101static int
102p9pdu_vreadf(struct p9_fcall *pdu, int proto_version, const char *fmt,
103 va_list ap)
104{
105 const char *ptr;
106 int errcode = 0;
107
108 for (ptr = fmt; *ptr; ptr++) {
109 switch (*ptr) {
110 case 'b':{
111 int8_t *val = va_arg(ap, int8_t *);
112 if (pdu_read(pdu, val, sizeof(*val))) {
113 errcode = -EFAULT;
114 break;
115 }
116 }
117 break;
118 case 'w':{
119 int16_t *val = va_arg(ap, int16_t *);
120 __le16 le_val;
121 if (pdu_read(pdu, &le_val, sizeof(le_val))) {
122 errcode = -EFAULT;
123 break;
124 }
125 *val = le16_to_cpu(le_val);
126 }
127 break;
128 case 'd':{
129 int32_t *val = va_arg(ap, int32_t *);
130 __le32 le_val;
131 if (pdu_read(pdu, &le_val, sizeof(le_val))) {
132 errcode = -EFAULT;
133 break;
134 }
135 *val = le32_to_cpu(le_val);
136 }
137 break;
138 case 'q':{
139 int64_t *val = va_arg(ap, int64_t *);
140 __le64 le_val;
141 if (pdu_read(pdu, &le_val, sizeof(le_val))) {
142 errcode = -EFAULT;
143 break;
144 }
145 *val = le64_to_cpu(le_val);
146 }
147 break;
148 case 's':{
149 char **sptr = va_arg(ap, char **);
150 uint16_t len;
151
152 errcode = p9pdu_readf(pdu, proto_version,
153 "w", &len);
154 if (errcode)
155 break;
156
157 *sptr = kmalloc(len + 1, GFP_NOFS);
158 if (*sptr == NULL) {
159 errcode = -EFAULT;
160 break;
161 }
162 if (pdu_read(pdu, *sptr, len)) {
163 errcode = -EFAULT;
164 kfree(*sptr);
165 *sptr = NULL;
166 } else
167 (*sptr)[len] = 0;
168 }
169 break;
170 case 'u': {
171 kuid_t *uid = va_arg(ap, kuid_t *);
172 __le32 le_val;
173 if (pdu_read(pdu, &le_val, sizeof(le_val))) {
174 errcode = -EFAULT;
175 break;
176 }
177 *uid = make_kuid(&init_user_ns,
178 le32_to_cpu(le_val));
179 } break;
180 case 'g': {
181 kgid_t *gid = va_arg(ap, kgid_t *);
182 __le32 le_val;
183 if (pdu_read(pdu, &le_val, sizeof(le_val))) {
184 errcode = -EFAULT;
185 break;
186 }
187 *gid = make_kgid(&init_user_ns,
188 le32_to_cpu(le_val));
189 } break;
190 case 'Q':{
191 struct p9_qid *qid =
192 va_arg(ap, struct p9_qid *);
193
194 errcode = p9pdu_readf(pdu, proto_version, "bdq",
195 &qid->type, &qid->version,
196 &qid->path);
197 }
198 break;
199 case 'S':{
200 struct p9_wstat *stbuf =
201 va_arg(ap, struct p9_wstat *);
202
203 memset(stbuf, 0, sizeof(struct p9_wstat));
204 stbuf->n_uid = stbuf->n_muid = INVALID_UID;
205 stbuf->n_gid = INVALID_GID;
206
207 errcode =
208 p9pdu_readf(pdu, proto_version,
209 "wwdQdddqssss?sugu",
210 &stbuf->size, &stbuf->type,
211 &stbuf->dev, &stbuf->qid,
212 &stbuf->mode, &stbuf->atime,
213 &stbuf->mtime, &stbuf->length,
214 &stbuf->name, &stbuf->uid,
215 &stbuf->gid, &stbuf->muid,
216 &stbuf->extension,
217 &stbuf->n_uid, &stbuf->n_gid,
218 &stbuf->n_muid);
219 if (errcode)
220 p9stat_free(stbuf);
221 }
222 break;
223 case 'D':{
224 uint32_t *count = va_arg(ap, uint32_t *);
225 void **data = va_arg(ap, void **);
226
227 errcode =
228 p9pdu_readf(pdu, proto_version, "d", count);
229 if (!errcode) {
230 *count =
231 min_t(uint32_t, *count,
232 pdu->size - pdu->offset);
233 *data = &pdu->sdata[pdu->offset];
234 }
235 }
236 break;
237 case 'T':{
238 uint16_t *nwname = va_arg(ap, uint16_t *);
239 char ***wnames = va_arg(ap, char ***);
240
241 errcode = p9pdu_readf(pdu, proto_version,
242 "w", nwname);
243 if (!errcode) {
244 *wnames =
245 kmalloc(sizeof(char *) * *nwname,
246 GFP_NOFS);
247 if (!*wnames)
248 errcode = -ENOMEM;
249 }
250
251 if (!errcode) {
252 int i;
253
254 for (i = 0; i < *nwname; i++) {
255 errcode =
256 p9pdu_readf(pdu,
257 proto_version,
258 "s",
259 &(*wnames)[i]);
260 if (errcode)
261 break;
262 }
263 }
264
265 if (errcode) {
266 if (*wnames) {
267 int i;
268
269 for (i = 0; i < *nwname; i++)
270 kfree((*wnames)[i]);
271 }
272 kfree(*wnames);
273 *wnames = NULL;
274 }
275 }
276 break;
277 case 'R':{
278 uint16_t *nwqid = va_arg(ap, uint16_t *);
279 struct p9_qid **wqids =
280 va_arg(ap, struct p9_qid **);
281
282 *wqids = NULL;
283
284 errcode =
285 p9pdu_readf(pdu, proto_version, "w", nwqid);
286 if (!errcode) {
287 *wqids =
288 kmalloc(*nwqid *
289 sizeof(struct p9_qid),
290 GFP_NOFS);
291 if (*wqids == NULL)
292 errcode = -ENOMEM;
293 }
294
295 if (!errcode) {
296 int i;
297
298 for (i = 0; i < *nwqid; i++) {
299 errcode =
300 p9pdu_readf(pdu,
301 proto_version,
302 "Q",
303 &(*wqids)[i]);
304 if (errcode)
305 break;
306 }
307 }
308
309 if (errcode) {
310 kfree(*wqids);
311 *wqids = NULL;
312 }
313 }
314 break;
315 case 'A': {
316 struct p9_stat_dotl *stbuf =
317 va_arg(ap, struct p9_stat_dotl *);
318
319 memset(stbuf, 0, sizeof(struct p9_stat_dotl));
320 errcode =
321 p9pdu_readf(pdu, proto_version,
322 "qQdugqqqqqqqqqqqqqqq",
323 &stbuf->st_result_mask,
324 &stbuf->qid,
325 &stbuf->st_mode,
326 &stbuf->st_uid, &stbuf->st_gid,
327 &stbuf->st_nlink,
328 &stbuf->st_rdev, &stbuf->st_size,
329 &stbuf->st_blksize, &stbuf->st_blocks,
330 &stbuf->st_atime_sec,
331 &stbuf->st_atime_nsec,
332 &stbuf->st_mtime_sec,
333 &stbuf->st_mtime_nsec,
334 &stbuf->st_ctime_sec,
335 &stbuf->st_ctime_nsec,
336 &stbuf->st_btime_sec,
337 &stbuf->st_btime_nsec,
338 &stbuf->st_gen,
339 &stbuf->st_data_version);
340 }
341 break;
342 case '?':
343 if ((proto_version != p9_proto_2000u) &&
344 (proto_version != p9_proto_2000L))
345 return 0;
346 break;
347 default:
348 BUG();
349 break;
350 }
351
352 if (errcode)
353 break;
354 }
355
356 return errcode;
357}
358
359int
360p9pdu_vwritef(struct p9_fcall *pdu, int proto_version, const char *fmt,
361 va_list ap)
362{
363 const char *ptr;
364 int errcode = 0;
365
366 for (ptr = fmt; *ptr; ptr++) {
367 switch (*ptr) {
368 case 'b':{
369 int8_t val = va_arg(ap, int);
370 if (pdu_write(pdu, &val, sizeof(val)))
371 errcode = -EFAULT;
372 }
373 break;
374 case 'w':{
375 __le16 val = cpu_to_le16(va_arg(ap, int));
376 if (pdu_write(pdu, &val, sizeof(val)))
377 errcode = -EFAULT;
378 }
379 break;
380 case 'd':{
381 __le32 val = cpu_to_le32(va_arg(ap, int32_t));
382 if (pdu_write(pdu, &val, sizeof(val)))
383 errcode = -EFAULT;
384 }
385 break;
386 case 'q':{
387 __le64 val = cpu_to_le64(va_arg(ap, int64_t));
388 if (pdu_write(pdu, &val, sizeof(val)))
389 errcode = -EFAULT;
390 }
391 break;
392 case 's':{
393 const char *sptr = va_arg(ap, const char *);
394 uint16_t len = 0;
395 if (sptr)
396 len = min_t(size_t, strlen(sptr),
397 USHRT_MAX);
398
399 errcode = p9pdu_writef(pdu, proto_version,
400 "w", len);
401 if (!errcode && pdu_write(pdu, sptr, len))
402 errcode = -EFAULT;
403 }
404 break;
405 case 'u': {
406 kuid_t uid = va_arg(ap, kuid_t);
407 __le32 val = cpu_to_le32(
408 from_kuid(&init_user_ns, uid));
409 if (pdu_write(pdu, &val, sizeof(val)))
410 errcode = -EFAULT;
411 } break;
412 case 'g': {
413 kgid_t gid = va_arg(ap, kgid_t);
414 __le32 val = cpu_to_le32(
415 from_kgid(&init_user_ns, gid));
416 if (pdu_write(pdu, &val, sizeof(val)))
417 errcode = -EFAULT;
418 } break;
419 case 'Q':{
420 const struct p9_qid *qid =
421 va_arg(ap, const struct p9_qid *);
422 errcode =
423 p9pdu_writef(pdu, proto_version, "bdq",
424 qid->type, qid->version,
425 qid->path);
426 } break;
427 case 'S':{
428 const struct p9_wstat *stbuf =
429 va_arg(ap, const struct p9_wstat *);
430 errcode =
431 p9pdu_writef(pdu, proto_version,
432 "wwdQdddqssss?sugu",
433 stbuf->size, stbuf->type,
434 stbuf->dev, &stbuf->qid,
435 stbuf->mode, stbuf->atime,
436 stbuf->mtime, stbuf->length,
437 stbuf->name, stbuf->uid,
438 stbuf->gid, stbuf->muid,
439 stbuf->extension, stbuf->n_uid,
440 stbuf->n_gid, stbuf->n_muid);
441 } break;
442 case 'V':{
443 uint32_t count = va_arg(ap, uint32_t);
444 struct iov_iter *from =
445 va_arg(ap, struct iov_iter *);
446 errcode = p9pdu_writef(pdu, proto_version, "d",
447 count);
448 if (!errcode && pdu_write_u(pdu, from, count))
449 errcode = -EFAULT;
450 }
451 break;
452 case 'T':{
453 uint16_t nwname = va_arg(ap, int);
454 const char **wnames = va_arg(ap, const char **);
455
456 errcode = p9pdu_writef(pdu, proto_version, "w",
457 nwname);
458 if (!errcode) {
459 int i;
460
461 for (i = 0; i < nwname; i++) {
462 errcode =
463 p9pdu_writef(pdu,
464 proto_version,
465 "s",
466 wnames[i]);
467 if (errcode)
468 break;
469 }
470 }
471 }
472 break;
473 case 'R':{
474 uint16_t nwqid = va_arg(ap, int);
475 struct p9_qid *wqids =
476 va_arg(ap, struct p9_qid *);
477
478 errcode = p9pdu_writef(pdu, proto_version, "w",
479 nwqid);
480 if (!errcode) {
481 int i;
482
483 for (i = 0; i < nwqid; i++) {
484 errcode =
485 p9pdu_writef(pdu,
486 proto_version,
487 "Q",
488 &wqids[i]);
489 if (errcode)
490 break;
491 }
492 }
493 }
494 break;
495 case 'I':{
496 struct p9_iattr_dotl *p9attr = va_arg(ap,
497 struct p9_iattr_dotl *);
498
499 errcode = p9pdu_writef(pdu, proto_version,
500 "ddugqqqqq",
501 p9attr->valid,
502 p9attr->mode,
503 p9attr->uid,
504 p9attr->gid,
505 p9attr->size,
506 p9attr->atime_sec,
507 p9attr->atime_nsec,
508 p9attr->mtime_sec,
509 p9attr->mtime_nsec);
510 }
511 break;
512 case '?':
513 if ((proto_version != p9_proto_2000u) &&
514 (proto_version != p9_proto_2000L))
515 return 0;
516 break;
517 default:
518 BUG();
519 break;
520 }
521
522 if (errcode)
523 break;
524 }
525
526 return errcode;
527}
528
529int p9pdu_readf(struct p9_fcall *pdu, int proto_version, const char *fmt, ...)
530{
531 va_list ap;
532 int ret;
533
534 va_start(ap, fmt);
535 ret = p9pdu_vreadf(pdu, proto_version, fmt, ap);
536 va_end(ap);
537
538 return ret;
539}
540
541static int
542p9pdu_writef(struct p9_fcall *pdu, int proto_version, const char *fmt, ...)
543{
544 va_list ap;
545 int ret;
546
547 va_start(ap, fmt);
548 ret = p9pdu_vwritef(pdu, proto_version, fmt, ap);
549 va_end(ap);
550
551 return ret;
552}
553
554int p9stat_read(struct p9_client *clnt, char *buf, int len, struct p9_wstat *st)
555{
556 struct p9_fcall fake_pdu;
557 int ret;
558
559 fake_pdu.size = len;
560 fake_pdu.capacity = len;
561 fake_pdu.sdata = buf;
562 fake_pdu.offset = 0;
563
564 ret = p9pdu_readf(&fake_pdu, clnt->proto_version, "S", st);
565 if (ret) {
566 p9_debug(P9_DEBUG_9P, "<<< p9stat_read failed: %d\n", ret);
567 trace_9p_protocol_dump(clnt, &fake_pdu);
568 }
569
570 return ret;
571}
572EXPORT_SYMBOL(p9stat_read);
573
574int p9pdu_prepare(struct p9_fcall *pdu, int16_t tag, int8_t type)
575{
576 pdu->id = type;
577 return p9pdu_writef(pdu, 0, "dbw", 0, type, tag);
578}
579
580int p9pdu_finalize(struct p9_client *clnt, struct p9_fcall *pdu)
581{
582 int size = pdu->size;
583 int err;
584
585 pdu->size = 0;
586 err = p9pdu_writef(pdu, 0, "d", size);
587 pdu->size = size;
588
589 trace_9p_protocol_dump(clnt, pdu);
590 p9_debug(P9_DEBUG_9P, ">>> size=%d type: %d tag: %d\n",
591 pdu->size, pdu->id, pdu->tag);
592
593 return err;
594}
595
596void p9pdu_reset(struct p9_fcall *pdu)
597{
598 pdu->offset = 0;
599 pdu->size = 0;
600}
601
602int p9dirent_read(struct p9_client *clnt, char *buf, int len,
603 struct p9_dirent *dirent)
604{
605 struct p9_fcall fake_pdu;
606 int ret;
607 char *nameptr;
608
609 fake_pdu.size = len;
610 fake_pdu.capacity = len;
611 fake_pdu.sdata = buf;
612 fake_pdu.offset = 0;
613
614 ret = p9pdu_readf(&fake_pdu, clnt->proto_version, "Qqbs", &dirent->qid,
615 &dirent->d_off, &dirent->d_type, &nameptr);
616 if (ret) {
617 p9_debug(P9_DEBUG_9P, "<<< p9dirent_read failed: %d\n", ret);
618 trace_9p_protocol_dump(clnt, &fake_pdu);
619 goto out;
620 }
621
622 strcpy(dirent->d_name, nameptr);
623 kfree(nameptr);
624
625out:
626 return fake_pdu.offset;
627}
628EXPORT_SYMBOL(p9dirent_read);
1// SPDX-License-Identifier: GPL-2.0-only
2/*
3 * 9P Protocol Support Code
4 *
5 * Copyright (C) 2008 by Eric Van Hensbergen <ericvh@gmail.com>
6 *
7 * Base on code from Anthony Liguori <aliguori@us.ibm.com>
8 * Copyright (C) 2008 by IBM, Corp.
9 */
10
11#include <linux/module.h>
12#include <linux/errno.h>
13#include <linux/kernel.h>
14#include <linux/uaccess.h>
15#include <linux/slab.h>
16#include <linux/sched.h>
17#include <linux/stddef.h>
18#include <linux/types.h>
19#include <linux/uio.h>
20#include <net/9p/9p.h>
21#include <net/9p/client.h>
22#include "protocol.h"
23
24#include <trace/events/9p.h>
25
26/* len[2] text[len] */
27#define P9_STRLEN(s) \
28 (2 + min_t(size_t, s ? strlen(s) : 0, USHRT_MAX))
29
30/**
31 * p9_msg_buf_size - Returns a buffer size sufficiently large to hold the
32 * intended 9p message.
33 * @c: client
34 * @type: message type
35 * @fmt: format template for assembling request message
36 * (see p9pdu_vwritef)
37 * @ap: variable arguments to be fed to passed format template
38 * (see p9pdu_vwritef)
39 *
40 * Note: Even for response types (P9_R*) the format template and variable
41 * arguments must always be for the originating request type (P9_T*).
42 */
43size_t p9_msg_buf_size(struct p9_client *c, enum p9_msg_t type,
44 const char *fmt, va_list ap)
45{
46 /* size[4] type[1] tag[2] */
47 const int hdr = 4 + 1 + 2;
48 /* ename[s] errno[4] */
49 const int rerror_size = hdr + P9_ERRMAX + 4;
50 /* ecode[4] */
51 const int rlerror_size = hdr + 4;
52 const int err_size =
53 c->proto_version == p9_proto_2000L ? rlerror_size : rerror_size;
54
55 static_assert(NAME_MAX <= 4*1024, "p9_msg_buf_size() currently assumes "
56 "a max. allowed directory entry name length of 4k");
57
58 switch (type) {
59
60 /* message types not used at all */
61 case P9_TERROR:
62 case P9_TLERROR:
63 case P9_TAUTH:
64 case P9_RAUTH:
65 BUG();
66
67 /* variable length & potentially large message types */
68 case P9_TATTACH:
69 BUG_ON(strcmp("ddss?u", fmt));
70 va_arg(ap, int32_t);
71 va_arg(ap, int32_t);
72 {
73 const char *uname = va_arg(ap, const char *);
74 const char *aname = va_arg(ap, const char *);
75 /* fid[4] afid[4] uname[s] aname[s] n_uname[4] */
76 return hdr + 4 + 4 + P9_STRLEN(uname) + P9_STRLEN(aname) + 4;
77 }
78 case P9_TWALK:
79 BUG_ON(strcmp("ddT", fmt));
80 va_arg(ap, int32_t);
81 va_arg(ap, int32_t);
82 {
83 uint i, nwname = va_arg(ap, int);
84 size_t wname_all;
85 const char **wnames = va_arg(ap, const char **);
86 for (i = 0, wname_all = 0; i < nwname; ++i) {
87 wname_all += P9_STRLEN(wnames[i]);
88 }
89 /* fid[4] newfid[4] nwname[2] nwname*(wname[s]) */
90 return hdr + 4 + 4 + 2 + wname_all;
91 }
92 case P9_RWALK:
93 BUG_ON(strcmp("ddT", fmt));
94 va_arg(ap, int32_t);
95 va_arg(ap, int32_t);
96 {
97 uint nwname = va_arg(ap, int);
98 /* nwqid[2] nwqid*(wqid[13]) */
99 return max_t(size_t, hdr + 2 + nwname * 13, err_size);
100 }
101 case P9_TCREATE:
102 BUG_ON(strcmp("dsdb?s", fmt));
103 va_arg(ap, int32_t);
104 {
105 const char *name = va_arg(ap, const char *);
106 if (c->proto_version == p9_proto_legacy) {
107 /* fid[4] name[s] perm[4] mode[1] */
108 return hdr + 4 + P9_STRLEN(name) + 4 + 1;
109 } else {
110 va_arg(ap, int32_t);
111 va_arg(ap, int);
112 {
113 const char *ext = va_arg(ap, const char *);
114 /* fid[4] name[s] perm[4] mode[1] extension[s] */
115 return hdr + 4 + P9_STRLEN(name) + 4 + 1 + P9_STRLEN(ext);
116 }
117 }
118 }
119 case P9_TLCREATE:
120 BUG_ON(strcmp("dsddg", fmt));
121 va_arg(ap, int32_t);
122 {
123 const char *name = va_arg(ap, const char *);
124 /* fid[4] name[s] flags[4] mode[4] gid[4] */
125 return hdr + 4 + P9_STRLEN(name) + 4 + 4 + 4;
126 }
127 case P9_RREAD:
128 case P9_RREADDIR:
129 BUG_ON(strcmp("dqd", fmt));
130 va_arg(ap, int32_t);
131 va_arg(ap, int64_t);
132 {
133 const int32_t count = va_arg(ap, int32_t);
134 /* count[4] data[count] */
135 return max_t(size_t, hdr + 4 + count, err_size);
136 }
137 case P9_TWRITE:
138 BUG_ON(strcmp("dqV", fmt));
139 va_arg(ap, int32_t);
140 va_arg(ap, int64_t);
141 {
142 const int32_t count = va_arg(ap, int32_t);
143 /* fid[4] offset[8] count[4] data[count] */
144 return hdr + 4 + 8 + 4 + count;
145 }
146 case P9_TRENAMEAT:
147 BUG_ON(strcmp("dsds", fmt));
148 va_arg(ap, int32_t);
149 {
150 const char *oldname, *newname;
151 oldname = va_arg(ap, const char *);
152 va_arg(ap, int32_t);
153 newname = va_arg(ap, const char *);
154 /* olddirfid[4] oldname[s] newdirfid[4] newname[s] */
155 return hdr + 4 + P9_STRLEN(oldname) + 4 + P9_STRLEN(newname);
156 }
157 case P9_TSYMLINK:
158 BUG_ON(strcmp("dssg", fmt));
159 va_arg(ap, int32_t);
160 {
161 const char *name = va_arg(ap, const char *);
162 const char *symtgt = va_arg(ap, const char *);
163 /* fid[4] name[s] symtgt[s] gid[4] */
164 return hdr + 4 + P9_STRLEN(name) + P9_STRLEN(symtgt) + 4;
165 }
166
167 case P9_RERROR:
168 return rerror_size;
169 case P9_RLERROR:
170 return rlerror_size;
171
172 /* small message types */
173 case P9_TWSTAT:
174 case P9_RSTAT:
175 case P9_RREADLINK:
176 case P9_TXATTRWALK:
177 case P9_TXATTRCREATE:
178 case P9_TLINK:
179 case P9_TMKDIR:
180 case P9_TMKNOD:
181 case P9_TRENAME:
182 case P9_TUNLINKAT:
183 case P9_TLOCK:
184 return 8 * 1024;
185
186 /* tiny message types */
187 default:
188 return 4 * 1024;
189
190 }
191}
192
193static int
194p9pdu_writef(struct p9_fcall *pdu, int proto_version, const char *fmt, ...);
195
196void p9stat_free(struct p9_wstat *stbuf)
197{
198 kfree(stbuf->name);
199 stbuf->name = NULL;
200 kfree(stbuf->uid);
201 stbuf->uid = NULL;
202 kfree(stbuf->gid);
203 stbuf->gid = NULL;
204 kfree(stbuf->muid);
205 stbuf->muid = NULL;
206 kfree(stbuf->extension);
207 stbuf->extension = NULL;
208}
209EXPORT_SYMBOL(p9stat_free);
210
211size_t pdu_read(struct p9_fcall *pdu, void *data, size_t size)
212{
213 size_t len = min(pdu->size - pdu->offset, size);
214
215 memcpy(data, &pdu->sdata[pdu->offset], len);
216 pdu->offset += len;
217 return size - len;
218}
219
220static size_t pdu_write(struct p9_fcall *pdu, const void *data, size_t size)
221{
222 size_t len = min(pdu->capacity - pdu->size, size);
223
224 memcpy(&pdu->sdata[pdu->size], data, len);
225 pdu->size += len;
226 return size - len;
227}
228
229static size_t
230pdu_write_u(struct p9_fcall *pdu, struct iov_iter *from, size_t size)
231{
232 size_t len = min(pdu->capacity - pdu->size, size);
233
234 if (!copy_from_iter_full(&pdu->sdata[pdu->size], len, from))
235 len = 0;
236
237 pdu->size += len;
238 return size - len;
239}
240
241/* b - int8_t
242 * w - int16_t
243 * d - int32_t
244 * q - int64_t
245 * s - string
246 * u - numeric uid
247 * g - numeric gid
248 * S - stat
249 * Q - qid
250 * D - data blob (int32_t size followed by void *, results are not freed)
251 * T - array of strings (int16_t count, followed by strings)
252 * R - array of qids (int16_t count, followed by qids)
253 * A - stat for 9p2000.L (p9_stat_dotl)
254 * ? - if optional = 1, continue parsing
255 */
256
257static int
258p9pdu_vreadf(struct p9_fcall *pdu, int proto_version, const char *fmt,
259 va_list ap)
260{
261 const char *ptr;
262 int errcode = 0;
263
264 for (ptr = fmt; *ptr; ptr++) {
265 switch (*ptr) {
266 case 'b':{
267 int8_t *val = va_arg(ap, int8_t *);
268 if (pdu_read(pdu, val, sizeof(*val))) {
269 errcode = -EFAULT;
270 break;
271 }
272 }
273 break;
274 case 'w':{
275 int16_t *val = va_arg(ap, int16_t *);
276 __le16 le_val;
277 if (pdu_read(pdu, &le_val, sizeof(le_val))) {
278 errcode = -EFAULT;
279 break;
280 }
281 *val = le16_to_cpu(le_val);
282 }
283 break;
284 case 'd':{
285 int32_t *val = va_arg(ap, int32_t *);
286 __le32 le_val;
287 if (pdu_read(pdu, &le_val, sizeof(le_val))) {
288 errcode = -EFAULT;
289 break;
290 }
291 *val = le32_to_cpu(le_val);
292 }
293 break;
294 case 'q':{
295 int64_t *val = va_arg(ap, int64_t *);
296 __le64 le_val;
297 if (pdu_read(pdu, &le_val, sizeof(le_val))) {
298 errcode = -EFAULT;
299 break;
300 }
301 *val = le64_to_cpu(le_val);
302 }
303 break;
304 case 's':{
305 char **sptr = va_arg(ap, char **);
306 uint16_t len;
307
308 errcode = p9pdu_readf(pdu, proto_version,
309 "w", &len);
310 if (errcode)
311 break;
312
313 *sptr = kmalloc(len + 1, GFP_NOFS);
314 if (*sptr == NULL) {
315 errcode = -ENOMEM;
316 break;
317 }
318 if (pdu_read(pdu, *sptr, len)) {
319 errcode = -EFAULT;
320 kfree(*sptr);
321 *sptr = NULL;
322 } else
323 (*sptr)[len] = 0;
324 }
325 break;
326 case 'u': {
327 kuid_t *uid = va_arg(ap, kuid_t *);
328 __le32 le_val;
329 if (pdu_read(pdu, &le_val, sizeof(le_val))) {
330 errcode = -EFAULT;
331 break;
332 }
333 *uid = make_kuid(&init_user_ns,
334 le32_to_cpu(le_val));
335 } break;
336 case 'g': {
337 kgid_t *gid = va_arg(ap, kgid_t *);
338 __le32 le_val;
339 if (pdu_read(pdu, &le_val, sizeof(le_val))) {
340 errcode = -EFAULT;
341 break;
342 }
343 *gid = make_kgid(&init_user_ns,
344 le32_to_cpu(le_val));
345 } break;
346 case 'Q':{
347 struct p9_qid *qid =
348 va_arg(ap, struct p9_qid *);
349
350 errcode = p9pdu_readf(pdu, proto_version, "bdq",
351 &qid->type, &qid->version,
352 &qid->path);
353 }
354 break;
355 case 'S':{
356 struct p9_wstat *stbuf =
357 va_arg(ap, struct p9_wstat *);
358
359 memset(stbuf, 0, sizeof(struct p9_wstat));
360 stbuf->n_uid = stbuf->n_muid = INVALID_UID;
361 stbuf->n_gid = INVALID_GID;
362
363 errcode =
364 p9pdu_readf(pdu, proto_version,
365 "wwdQdddqssss?sugu",
366 &stbuf->size, &stbuf->type,
367 &stbuf->dev, &stbuf->qid,
368 &stbuf->mode, &stbuf->atime,
369 &stbuf->mtime, &stbuf->length,
370 &stbuf->name, &stbuf->uid,
371 &stbuf->gid, &stbuf->muid,
372 &stbuf->extension,
373 &stbuf->n_uid, &stbuf->n_gid,
374 &stbuf->n_muid);
375 if (errcode)
376 p9stat_free(stbuf);
377 }
378 break;
379 case 'D':{
380 uint32_t *count = va_arg(ap, uint32_t *);
381 void **data = va_arg(ap, void **);
382
383 errcode =
384 p9pdu_readf(pdu, proto_version, "d", count);
385 if (!errcode) {
386 *count =
387 min_t(uint32_t, *count,
388 pdu->size - pdu->offset);
389 *data = &pdu->sdata[pdu->offset];
390 }
391 }
392 break;
393 case 'T':{
394 uint16_t *nwname = va_arg(ap, uint16_t *);
395 char ***wnames = va_arg(ap, char ***);
396
397 *wnames = NULL;
398
399 errcode = p9pdu_readf(pdu, proto_version,
400 "w", nwname);
401 if (!errcode) {
402 *wnames =
403 kmalloc_array(*nwname,
404 sizeof(char *),
405 GFP_NOFS);
406 if (!*wnames)
407 errcode = -ENOMEM;
408 else
409 (*wnames)[0] = NULL;
410 }
411
412 if (!errcode) {
413 int i;
414
415 for (i = 0; i < *nwname; i++) {
416 errcode =
417 p9pdu_readf(pdu,
418 proto_version,
419 "s",
420 &(*wnames)[i]);
421 if (errcode) {
422 (*wnames)[i] = NULL;
423 break;
424 }
425 }
426 }
427
428 if (errcode) {
429 if (*wnames) {
430 int i;
431
432 for (i = 0; i < *nwname; i++) {
433 if (!(*wnames)[i])
434 break;
435 kfree((*wnames)[i]);
436 }
437 kfree(*wnames);
438 *wnames = NULL;
439 }
440 }
441 }
442 break;
443 case 'R':{
444 uint16_t *nwqid = va_arg(ap, uint16_t *);
445 struct p9_qid **wqids =
446 va_arg(ap, struct p9_qid **);
447
448 *wqids = NULL;
449
450 errcode =
451 p9pdu_readf(pdu, proto_version, "w", nwqid);
452 if (!errcode) {
453 *wqids =
454 kmalloc_array(*nwqid,
455 sizeof(struct p9_qid),
456 GFP_NOFS);
457 if (*wqids == NULL)
458 errcode = -ENOMEM;
459 }
460
461 if (!errcode) {
462 int i;
463
464 for (i = 0; i < *nwqid; i++) {
465 errcode =
466 p9pdu_readf(pdu,
467 proto_version,
468 "Q",
469 &(*wqids)[i]);
470 if (errcode)
471 break;
472 }
473 }
474
475 if (errcode) {
476 kfree(*wqids);
477 *wqids = NULL;
478 }
479 }
480 break;
481 case 'A': {
482 struct p9_stat_dotl *stbuf =
483 va_arg(ap, struct p9_stat_dotl *);
484
485 memset(stbuf, 0, sizeof(struct p9_stat_dotl));
486 errcode =
487 p9pdu_readf(pdu, proto_version,
488 "qQdugqqqqqqqqqqqqqqq",
489 &stbuf->st_result_mask,
490 &stbuf->qid,
491 &stbuf->st_mode,
492 &stbuf->st_uid, &stbuf->st_gid,
493 &stbuf->st_nlink,
494 &stbuf->st_rdev, &stbuf->st_size,
495 &stbuf->st_blksize, &stbuf->st_blocks,
496 &stbuf->st_atime_sec,
497 &stbuf->st_atime_nsec,
498 &stbuf->st_mtime_sec,
499 &stbuf->st_mtime_nsec,
500 &stbuf->st_ctime_sec,
501 &stbuf->st_ctime_nsec,
502 &stbuf->st_btime_sec,
503 &stbuf->st_btime_nsec,
504 &stbuf->st_gen,
505 &stbuf->st_data_version);
506 }
507 break;
508 case '?':
509 if ((proto_version != p9_proto_2000u) &&
510 (proto_version != p9_proto_2000L))
511 return 0;
512 break;
513 default:
514 BUG();
515 break;
516 }
517
518 if (errcode)
519 break;
520 }
521
522 return errcode;
523}
524
525int
526p9pdu_vwritef(struct p9_fcall *pdu, int proto_version, const char *fmt,
527 va_list ap)
528{
529 const char *ptr;
530 int errcode = 0;
531
532 for (ptr = fmt; *ptr; ptr++) {
533 switch (*ptr) {
534 case 'b':{
535 int8_t val = va_arg(ap, int);
536 if (pdu_write(pdu, &val, sizeof(val)))
537 errcode = -EFAULT;
538 }
539 break;
540 case 'w':{
541 __le16 val = cpu_to_le16(va_arg(ap, int));
542 if (pdu_write(pdu, &val, sizeof(val)))
543 errcode = -EFAULT;
544 }
545 break;
546 case 'd':{
547 __le32 val = cpu_to_le32(va_arg(ap, int32_t));
548 if (pdu_write(pdu, &val, sizeof(val)))
549 errcode = -EFAULT;
550 }
551 break;
552 case 'q':{
553 __le64 val = cpu_to_le64(va_arg(ap, int64_t));
554 if (pdu_write(pdu, &val, sizeof(val)))
555 errcode = -EFAULT;
556 }
557 break;
558 case 's':{
559 const char *sptr = va_arg(ap, const char *);
560 uint16_t len = 0;
561 if (sptr)
562 len = min_t(size_t, strlen(sptr),
563 USHRT_MAX);
564
565 errcode = p9pdu_writef(pdu, proto_version,
566 "w", len);
567 if (!errcode && pdu_write(pdu, sptr, len))
568 errcode = -EFAULT;
569 }
570 break;
571 case 'u': {
572 kuid_t uid = va_arg(ap, kuid_t);
573 __le32 val = cpu_to_le32(
574 from_kuid(&init_user_ns, uid));
575 if (pdu_write(pdu, &val, sizeof(val)))
576 errcode = -EFAULT;
577 } break;
578 case 'g': {
579 kgid_t gid = va_arg(ap, kgid_t);
580 __le32 val = cpu_to_le32(
581 from_kgid(&init_user_ns, gid));
582 if (pdu_write(pdu, &val, sizeof(val)))
583 errcode = -EFAULT;
584 } break;
585 case 'Q':{
586 const struct p9_qid *qid =
587 va_arg(ap, const struct p9_qid *);
588 errcode =
589 p9pdu_writef(pdu, proto_version, "bdq",
590 qid->type, qid->version,
591 qid->path);
592 } break;
593 case 'S':{
594 const struct p9_wstat *stbuf =
595 va_arg(ap, const struct p9_wstat *);
596 errcode =
597 p9pdu_writef(pdu, proto_version,
598 "wwdQdddqssss?sugu",
599 stbuf->size, stbuf->type,
600 stbuf->dev, &stbuf->qid,
601 stbuf->mode, stbuf->atime,
602 stbuf->mtime, stbuf->length,
603 stbuf->name, stbuf->uid,
604 stbuf->gid, stbuf->muid,
605 stbuf->extension, stbuf->n_uid,
606 stbuf->n_gid, stbuf->n_muid);
607 } break;
608 case 'V':{
609 uint32_t count = va_arg(ap, uint32_t);
610 struct iov_iter *from =
611 va_arg(ap, struct iov_iter *);
612 errcode = p9pdu_writef(pdu, proto_version, "d",
613 count);
614 if (!errcode && pdu_write_u(pdu, from, count))
615 errcode = -EFAULT;
616 }
617 break;
618 case 'T':{
619 uint16_t nwname = va_arg(ap, int);
620 const char **wnames = va_arg(ap, const char **);
621
622 errcode = p9pdu_writef(pdu, proto_version, "w",
623 nwname);
624 if (!errcode) {
625 int i;
626
627 for (i = 0; i < nwname; i++) {
628 errcode =
629 p9pdu_writef(pdu,
630 proto_version,
631 "s",
632 wnames[i]);
633 if (errcode)
634 break;
635 }
636 }
637 }
638 break;
639 case 'R':{
640 uint16_t nwqid = va_arg(ap, int);
641 struct p9_qid *wqids =
642 va_arg(ap, struct p9_qid *);
643
644 errcode = p9pdu_writef(pdu, proto_version, "w",
645 nwqid);
646 if (!errcode) {
647 int i;
648
649 for (i = 0; i < nwqid; i++) {
650 errcode =
651 p9pdu_writef(pdu,
652 proto_version,
653 "Q",
654 &wqids[i]);
655 if (errcode)
656 break;
657 }
658 }
659 }
660 break;
661 case 'I':{
662 struct p9_iattr_dotl *p9attr = va_arg(ap,
663 struct p9_iattr_dotl *);
664
665 errcode = p9pdu_writef(pdu, proto_version,
666 "ddugqqqqq",
667 p9attr->valid,
668 p9attr->mode,
669 p9attr->uid,
670 p9attr->gid,
671 p9attr->size,
672 p9attr->atime_sec,
673 p9attr->atime_nsec,
674 p9attr->mtime_sec,
675 p9attr->mtime_nsec);
676 }
677 break;
678 case '?':
679 if ((proto_version != p9_proto_2000u) &&
680 (proto_version != p9_proto_2000L))
681 return 0;
682 break;
683 default:
684 BUG();
685 break;
686 }
687
688 if (errcode)
689 break;
690 }
691
692 return errcode;
693}
694
695int p9pdu_readf(struct p9_fcall *pdu, int proto_version, const char *fmt, ...)
696{
697 va_list ap;
698 int ret;
699
700 va_start(ap, fmt);
701 ret = p9pdu_vreadf(pdu, proto_version, fmt, ap);
702 va_end(ap);
703
704 return ret;
705}
706
707static int
708p9pdu_writef(struct p9_fcall *pdu, int proto_version, const char *fmt, ...)
709{
710 va_list ap;
711 int ret;
712
713 va_start(ap, fmt);
714 ret = p9pdu_vwritef(pdu, proto_version, fmt, ap);
715 va_end(ap);
716
717 return ret;
718}
719
720int p9stat_read(struct p9_client *clnt, char *buf, int len, struct p9_wstat *st)
721{
722 struct p9_fcall fake_pdu;
723 int ret;
724
725 fake_pdu.size = len;
726 fake_pdu.capacity = len;
727 fake_pdu.sdata = buf;
728 fake_pdu.offset = 0;
729
730 ret = p9pdu_readf(&fake_pdu, clnt->proto_version, "S", st);
731 if (ret) {
732 p9_debug(P9_DEBUG_9P, "<<< p9stat_read failed: %d\n", ret);
733 trace_9p_protocol_dump(clnt, &fake_pdu);
734 return ret;
735 }
736
737 return fake_pdu.offset;
738}
739EXPORT_SYMBOL(p9stat_read);
740
741int p9pdu_prepare(struct p9_fcall *pdu, int16_t tag, int8_t type)
742{
743 pdu->id = type;
744 return p9pdu_writef(pdu, 0, "dbw", 0, type, tag);
745}
746
747int p9pdu_finalize(struct p9_client *clnt, struct p9_fcall *pdu)
748{
749 int size = pdu->size;
750 int err;
751
752 pdu->size = 0;
753 err = p9pdu_writef(pdu, 0, "d", size);
754 pdu->size = size;
755
756 trace_9p_protocol_dump(clnt, pdu);
757 p9_debug(P9_DEBUG_9P, ">>> size=%d type: %d tag: %d\n",
758 pdu->size, pdu->id, pdu->tag);
759
760 return err;
761}
762
763void p9pdu_reset(struct p9_fcall *pdu)
764{
765 pdu->offset = 0;
766 pdu->size = 0;
767}
768
769int p9dirent_read(struct p9_client *clnt, char *buf, int len,
770 struct p9_dirent *dirent)
771{
772 struct p9_fcall fake_pdu;
773 int ret;
774 char *nameptr;
775
776 fake_pdu.size = len;
777 fake_pdu.capacity = len;
778 fake_pdu.sdata = buf;
779 fake_pdu.offset = 0;
780
781 ret = p9pdu_readf(&fake_pdu, clnt->proto_version, "Qqbs", &dirent->qid,
782 &dirent->d_off, &dirent->d_type, &nameptr);
783 if (ret) {
784 p9_debug(P9_DEBUG_9P, "<<< p9dirent_read failed: %d\n", ret);
785 trace_9p_protocol_dump(clnt, &fake_pdu);
786 return ret;
787 }
788
789 ret = strscpy(dirent->d_name, nameptr, sizeof(dirent->d_name));
790 if (ret < 0) {
791 p9_debug(P9_DEBUG_ERROR,
792 "On the wire dirent name too long: %s\n",
793 nameptr);
794 kfree(nameptr);
795 return ret;
796 }
797 kfree(nameptr);
798
799 return fake_pdu.offset;
800}
801EXPORT_SYMBOL(p9dirent_read);