err.no Git - linux-2.6/blob - net/9p/conv.c

   1 /*
   2  * net/9p/conv.c
   3  *
   4  * 9P protocol conversion functions
   5  *
   6  *  Copyright (C) 2004, 2005 by Latchesar Ionkov <lucho@ionkov.net>
   7  *  Copyright (C) 2004 by Eric Van Hensbergen <ericvh@gmail.com>
   8  *  Copyright (C) 2002 by Ron Minnich <rminnich@lanl.gov>
   9  *
  10  *  This program is free software; you can redistribute it and/or modify
  11  *  it under the terms of the GNU General Public License version 2
  12  *  as published by the Free Software Foundation.
  13  *
  14  *  This program is distributed in the hope that it will be useful,
  15  *  but WITHOUT ANY WARRANTY; without even the implied warranty of
  16  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  17  *  GNU General Public License for more details.
  18  *
  19  *  You should have received a copy of the GNU General Public License
  20  *  along with this program; if not, write to:
  21  *  Free Software Foundation
  22  *  51 Franklin Street, Fifth Floor
  23  *  Boston, MA  02111-1301  USA
  24  *
  25  */
  26
  27 #include <linux/module.h>
  28 #include <linux/errno.h>
  29 #include <linux/fs.h>
  30 #include <linux/sched.h>
  31 #include <linux/idr.h>
  32 #include <linux/uaccess.h>
  33 #include <net/9p/9p.h>
  34
  35 /*
  36  * Buffer to help with string parsing
  37  */
  38 struct cbuf {
  39         unsigned char *sp;
  40         unsigned char *p;
  41         unsigned char *ep;
  42 };
  43
  44 static inline void buf_init(struct cbuf *buf, void *data, int datalen)
  45 {
  46         buf->sp = buf->p = data;
  47         buf->ep = data + datalen;
  48 }
  49
  50 static inline int buf_check_overflow(struct cbuf *buf)
  51 {
  52         return buf->p > buf->ep;
  53 }
  54
  55 static int buf_check_size(struct cbuf *buf, int len)
  56 {
  57         if (buf->p + len > buf->ep) {
  58                 if (buf->p < buf->ep) {
  59                         P9_EPRINTK(KERN_ERR,
  60                                 "buffer overflow: want %d has %d\n", len,
  61                                 (int)(buf->ep - buf->p));
  62                         dump_stack();
  63                         buf->p = buf->ep + 1;
  64                 }
  65
  66                 return 0;
  67         }
  68
  69         return 1;
  70 }
  71
  72 static void *buf_alloc(struct cbuf *buf, int len)
  73 {
  74         void *ret = NULL;
  75
  76         if (buf_check_size(buf, len)) {
  77                 ret = buf->p;
  78                 buf->p += len;
  79         }
  80
  81         return ret;
  82 }
  83
  84 static void buf_put_int8(struct cbuf *buf, u8 val)
  85 {
  86         if (buf_check_size(buf, 1)) {
  87                 buf->p[0] = val;
  88                 buf->p++;
  89         }
  90 }
  91
  92 static void buf_put_int16(struct cbuf *buf, u16 val)
  93 {
  94         if (buf_check_size(buf, 2)) {
  95                 *(__le16 *) buf->p = cpu_to_le16(val);
  96                 buf->p += 2;
  97         }
  98 }
  99
 100 static void buf_put_int32(struct cbuf *buf, u32 val)
 101 {
 102         if (buf_check_size(buf, 4)) {
 103                 *(__le32 *)buf->p = cpu_to_le32(val);
 104                 buf->p += 4;
 105         }
 106 }
 107
 108 static void buf_put_int64(struct cbuf *buf, u64 val)
 109 {
 110         if (buf_check_size(buf, 8)) {
 111                 *(__le64 *)buf->p = cpu_to_le64(val);
 112                 buf->p += 8;
 113         }
 114 }
 115
 116 static char *buf_put_stringn(struct cbuf *buf, const char *s, u16 slen)
 117 {
 118         char *ret;
 119
 120         ret = NULL;
 121         if (buf_check_size(buf, slen + 2)) {
 122                 buf_put_int16(buf, slen);
 123                 ret = buf->p;
 124                 memcpy(buf->p, s, slen);
 125                 buf->p += slen;
 126         }
 127
 128         return ret;
 129 }
 130
 131 static u8 buf_get_int8(struct cbuf *buf)
 132 {
 133         u8 ret = 0;
 134
 135         if (buf_check_size(buf, 1)) {
 136                 ret = buf->p[0];
 137                 buf->p++;
 138         }
 139
 140         return ret;
 141 }
 142
 143 static u16 buf_get_int16(struct cbuf *buf)
 144 {
 145         u16 ret = 0;
 146
 147         if (buf_check_size(buf, 2)) {
 148                 ret = le16_to_cpu(*(__le16 *)buf->p);
 149                 buf->p += 2;
 150         }
 151
 152         return ret;
 153 }
 154
 155 static u32 buf_get_int32(struct cbuf *buf)
 156 {
 157         u32 ret = 0;
 158
 159         if (buf_check_size(buf, 4)) {
 160                 ret = le32_to_cpu(*(__le32 *)buf->p);
 161                 buf->p += 4;
 162         }
 163
 164         return ret;
 165 }
 166
 167 static u64 buf_get_int64(struct cbuf *buf)
 168 {
 169         u64 ret = 0;
 170
 171         if (buf_check_size(buf, 8)) {
 172                 ret = le64_to_cpu(*(__le64 *)buf->p);
 173                 buf->p += 8;
 174         }
 175
 176         return ret;
 177 }
 178
 179 static void buf_get_str(struct cbuf *buf, struct p9_str *vstr)
 180 {
 181         vstr->len = buf_get_int16(buf);
 182         if (!buf_check_overflow(buf) && buf_check_size(buf, vstr->len)) {
 183                 vstr->str = buf->p;
 184                 buf->p += vstr->len;
 185         } else {
 186                 vstr->len = 0;
 187                 vstr->str = NULL;
 188         }
 189 }
 190
 191 static void buf_get_qid(struct cbuf *bufp, struct p9_qid *qid)
 192 {
 193         qid->type = buf_get_int8(bufp);
 194         qid->version = buf_get_int32(bufp);
 195         qid->path = buf_get_int64(bufp);
 196 }
 197
 198 /**
 199  * p9_size_wstat - calculate the size of a variable length stat struct
 200  * @wstat: metadata (stat) structure
 201  * @dotu: non-zero if 9P2000.u
 202  *
 203  */
 204
 205 static int p9_size_wstat(struct p9_wstat *wstat, int dotu)
 206 {
 207         int size = 0;
 208
 209         if (wstat == NULL) {
 210                 P9_EPRINTK(KERN_ERR, "p9_size_stat: got a NULL stat pointer\n");
 211                 return 0;
 212         }
 213
 214         size =                  /* 2 + *//* size[2] */
 215             2 +                 /* type[2] */
 216             4 +                 /* dev[4] */
 217             1 +                 /* qid.type[1] */
 218             4 +                 /* qid.vers[4] */
 219             8 +                 /* qid.path[8] */
 220             4 +                 /* mode[4] */
 221             4 +                 /* atime[4] */
 222             4 +                 /* mtime[4] */
 223             8 +                 /* length[8] */
 224             8;                  /* minimum sum of string lengths */
 225
 226         if (wstat->name)
 227                 size += strlen(wstat->name);
 228         if (wstat->uid)
 229                 size += strlen(wstat->uid);
 230         if (wstat->gid)
 231                 size += strlen(wstat->gid);
 232         if (wstat->muid)
 233                 size += strlen(wstat->muid);
 234
 235         if (dotu) {
 236                 size += 4 +     /* n_uid[4] */
 237                     4 +         /* n_gid[4] */
 238                     4 +         /* n_muid[4] */
 239                     2;          /* string length of extension[4] */
 240                 if (wstat->extension)
 241                         size += strlen(wstat->extension);
 242         }
 243
 244         return size;
 245 }
 246
 247 /**
 248  * buf_get_stat - safely decode a recieved metadata (stat) structure
 249  * @bufp: buffer to deserialize
 250  * @stat: metadata (stat) structure
 251  * @dotu: non-zero if 9P2000.u
 252  *
 253  */
 254
 255 static void
 256 buf_get_stat(struct cbuf *bufp, struct p9_stat *stat, int dotu)
 257 {
 258         stat->size = buf_get_int16(bufp);
 259         stat->type = buf_get_int16(bufp);
 260         stat->dev = buf_get_int32(bufp);
 261         stat->qid.type = buf_get_int8(bufp);
 262         stat->qid.version = buf_get_int32(bufp);
 263         stat->qid.path = buf_get_int64(bufp);
 264         stat->mode = buf_get_int32(bufp);
 265         stat->atime = buf_get_int32(bufp);
 266         stat->mtime = buf_get_int32(bufp);
 267         stat->length = buf_get_int64(bufp);
 268         buf_get_str(bufp, &stat->name);
 269         buf_get_str(bufp, &stat->uid);
 270         buf_get_str(bufp, &stat->gid);
 271         buf_get_str(bufp, &stat->muid);
 272
 273         if (dotu) {
 274                 buf_get_str(bufp, &stat->extension);
 275                 stat->n_uid = buf_get_int32(bufp);
 276                 stat->n_gid = buf_get_int32(bufp);
 277                 stat->n_muid = buf_get_int32(bufp);
 278         }
 279 }
 280
 281 /**
 282  * p9_deserialize_stat - decode a received metadata structure
 283  * @buf: buffer to deserialize
 284  * @buflen: length of received buffer
 285  * @stat: metadata structure to decode into
 286  * @dotu: non-zero if 9P2000.u
 287  *
 288  * Note: stat will point to the buf region.
 289  */
 290
 291 int
 292 p9_deserialize_stat(void *buf, u32 buflen, struct p9_stat *stat,
 293                 int dotu)
 294 {
 295         struct cbuf buffer;
 296         struct cbuf *bufp = &buffer;
 297         unsigned char *p;
 298
 299         buf_init(bufp, buf, buflen);
 300         p = bufp->p;
 301         buf_get_stat(bufp, stat, dotu);
 302
 303         if (buf_check_overflow(bufp))
 304                 return 0;
 305         else
 306                 return bufp->p - p;
 307 }
 308 EXPORT_SYMBOL(p9_deserialize_stat);
 309
 310 /**
 311  * deserialize_fcall - unmarshal a response
 312  * @buf: recieved buffer
 313  * @buflen: length of received buffer
 314  * @rcall: fcall structure to populate
 315  * @rcalllen: length of fcall structure to populate
 316  * @dotu: non-zero if 9P2000.u
 317  *
 318  */
 319
 320 int
 321 p9_deserialize_fcall(void *buf, u32 buflen, struct p9_fcall *rcall,
 322                        int dotu)
 323 {
 324
 325         struct cbuf buffer;
 326         struct cbuf *bufp = &buffer;
 327         int i = 0;
 328
 329         buf_init(bufp, buf, buflen);
 330
 331         rcall->size = buf_get_int32(bufp);
 332         rcall->id = buf_get_int8(bufp);
 333         rcall->tag = buf_get_int16(bufp);
 334
 335         P9_DPRINTK(P9_DEBUG_CONV, "size %d id %d tag %d\n", rcall->size,
 336                                                         rcall->id, rcall->tag);
 337
 338         switch (rcall->id) {
 339         default:
 340                 P9_EPRINTK(KERN_ERR, "unknown message type: %d\n", rcall->id);
 341                 return -EPROTO;
 342         case P9_RVERSION:
 343                 rcall->params.rversion.msize = buf_get_int32(bufp);
 344                 buf_get_str(bufp, &rcall->params.rversion.version);
 345                 break;
 346         case P9_RFLUSH:
 347                 break;
 348         case P9_RATTACH:
 349                 rcall->params.rattach.qid.type = buf_get_int8(bufp);
 350                 rcall->params.rattach.qid.version = buf_get_int32(bufp);
 351                 rcall->params.rattach.qid.path = buf_get_int64(bufp);
 352                 break;
 353         case P9_RWALK:
 354                 rcall->params.rwalk.nwqid = buf_get_int16(bufp);
 355                 if (rcall->params.rwalk.nwqid > P9_MAXWELEM) {
 356                         P9_EPRINTK(KERN_ERR,
 357                                         "Rwalk with more than %d qids: %d\n",
 358                                         P9_MAXWELEM, rcall->params.rwalk.nwqid);
 359                         return -EPROTO;
 360                 }
 361
 362                 for (i = 0; i < rcall->params.rwalk.nwqid; i++)
 363                         buf_get_qid(bufp, &rcall->params.rwalk.wqids[i]);
 364                 break;
 365         case P9_ROPEN:
 366                 buf_get_qid(bufp, &rcall->params.ropen.qid);
 367                 rcall->params.ropen.iounit = buf_get_int32(bufp);
 368                 break;
 369         case P9_RCREATE:
 370                 buf_get_qid(bufp, &rcall->params.rcreate.qid);
 371                 rcall->params.rcreate.iounit = buf_get_int32(bufp);
 372                 break;
 373         case P9_RREAD:
 374                 rcall->params.rread.count = buf_get_int32(bufp);
 375                 rcall->params.rread.data = bufp->p;
 376                 buf_check_size(bufp, rcall->params.rread.count);
 377                 break;
 378         case P9_RWRITE:
 379                 rcall->params.rwrite.count = buf_get_int32(bufp);
 380                 break;
 381         case P9_RCLUNK:
 382                 break;
 383         case P9_RREMOVE:
 384                 break;
 385         case P9_RSTAT:
 386                 buf_get_int16(bufp);
 387                 buf_get_stat(bufp, &rcall->params.rstat.stat, dotu);
 388                 break;
 389         case P9_RWSTAT:
 390                 break;
 391         case P9_RERROR:
 392                 buf_get_str(bufp, &rcall->params.rerror.error);
 393                 if (dotu)
 394                         rcall->params.rerror.errno = buf_get_int16(bufp);
 395                 break;
 396         }
 397
 398         if (buf_check_overflow(bufp)) {
 399                 P9_DPRINTK(P9_DEBUG_ERROR, "buffer overflow\n");
 400                 return -EIO;
 401         }
 402
 403         return bufp->p - bufp->sp;
 404 }
 405 EXPORT_SYMBOL(p9_deserialize_fcall);
 406
 407 static inline void p9_put_int8(struct cbuf *bufp, u8 val, u8 * p)
 408 {
 409         *p = val;
 410         buf_put_int8(bufp, val);
 411 }
 412
 413 static inline void p9_put_int16(struct cbuf *bufp, u16 val, u16 * p)
 414 {
 415         *p = val;
 416         buf_put_int16(bufp, val);
 417 }
 418
 419 static inline void p9_put_int32(struct cbuf *bufp, u32 val, u32 * p)
 420 {
 421         *p = val;
 422         buf_put_int32(bufp, val);
 423 }
 424
 425 static inline void p9_put_int64(struct cbuf *bufp, u64 val, u64 * p)
 426 {
 427         *p = val;
 428         buf_put_int64(bufp, val);
 429 }
 430
 431 static void
 432 p9_put_str(struct cbuf *bufp, char *data, struct p9_str *str)
 433 {
 434         int len;
 435         char *s;
 436
 437         if (data)
 438                 len = strlen(data);
 439         else
 440                 len = 0;
 441
 442         s = buf_put_stringn(bufp, data, len);
 443         if (str) {
 444                 str->len = len;
 445                 str->str = s;
 446         }
 447 }
 448
 449 static int
 450 p9_put_data(struct cbuf *bufp, const char *data, int count,
 451                    unsigned char **pdata)
 452 {
 453         *pdata = buf_alloc(bufp, count);
 454         memmove(*pdata, data, count);
 455         return count;
 456 }
 457
 458 static int
 459 p9_put_user_data(struct cbuf *bufp, const char __user *data, int count,
 460                    unsigned char **pdata)
 461 {
 462         *pdata = buf_alloc(bufp, count);
 463         return copy_from_user(*pdata, data, count);
 464 }
 465
 466 static void
 467 p9_put_wstat(struct cbuf *bufp, struct p9_wstat *wstat,
 468                struct p9_stat *stat, int statsz, int dotu)
 469 {
 470         p9_put_int16(bufp, statsz, &stat->size);
 471         p9_put_int16(bufp, wstat->type, &stat->type);
 472         p9_put_int32(bufp, wstat->dev, &stat->dev);
 473         p9_put_int8(bufp, wstat->qid.type, &stat->qid.type);
 474         p9_put_int32(bufp, wstat->qid.version, &stat->qid.version);
 475         p9_put_int64(bufp, wstat->qid.path, &stat->qid.path);
 476         p9_put_int32(bufp, wstat->mode, &stat->mode);
 477         p9_put_int32(bufp, wstat->atime, &stat->atime);
 478         p9_put_int32(bufp, wstat->mtime, &stat->mtime);
 479         p9_put_int64(bufp, wstat->length, &stat->length);
 480
 481         p9_put_str(bufp, wstat->name, &stat->name);
 482         p9_put_str(bufp, wstat->uid, &stat->uid);
 483         p9_put_str(bufp, wstat->gid, &stat->gid);
 484         p9_put_str(bufp, wstat->muid, &stat->muid);
 485
 486         if (dotu) {
 487                 p9_put_str(bufp, wstat->extension, &stat->extension);
 488                 p9_put_int32(bufp, wstat->n_uid, &stat->n_uid);
 489                 p9_put_int32(bufp, wstat->n_gid, &stat->n_gid);
 490                 p9_put_int32(bufp, wstat->n_muid, &stat->n_muid);
 491         }
 492 }
 493
 494 static struct p9_fcall *
 495 p9_create_common(struct cbuf *bufp, u32 size, u8 id)
 496 {
 497         struct p9_fcall *fc;
 498
 499         size += 4 + 1 + 2;      /* size[4] id[1] tag[2] */
 500         fc = kmalloc(sizeof(struct p9_fcall) + size, GFP_KERNEL);
 501         if (!fc)
 502                 return ERR_PTR(-ENOMEM);
 503
 504         fc->sdata = (char *)fc + sizeof(*fc);
 505
 506         buf_init(bufp, (char *)fc->sdata, size);
 507         p9_put_int32(bufp, size, &fc->size);
 508         p9_put_int8(bufp, id, &fc->id);
 509         p9_put_int16(bufp, P9_NOTAG, &fc->tag);
 510
 511         return fc;
 512 }
 513
 514 /**
 515  * p9_set_tag - set the tag field of an &p9_fcall structure
 516  * @fc: fcall structure to set tag within
 517  * @tag: tag id to set
 518  */
 519
 520 void p9_set_tag(struct p9_fcall *fc, u16 tag)
 521 {
 522         fc->tag = tag;
 523         *(__le16 *) (fc->sdata + 5) = cpu_to_le16(tag);
 524 }
 525 EXPORT_SYMBOL(p9_set_tag);
 526
 527 /**
 528  * p9_create_tversion - allocates and creates a T_VERSION request
 529  * @msize: requested maximum data size
 530  * @version: version string to negotiate
 531  *
 532  */
 533 struct p9_fcall *p9_create_tversion(u32 msize, char *version)
 534 {
 535         int size;
 536         struct p9_fcall *fc;
 537         struct cbuf buffer;
 538         struct cbuf *bufp = &buffer;
 539
 540         size = 4 + 2 + strlen(version); /* msize[4] version[s] */
 541         fc = p9_create_common(bufp, size, P9_TVERSION);
 542         if (IS_ERR(fc))
 543                 goto error;
 544
 545         p9_put_int32(bufp, msize, &fc->params.tversion.msize);
 546         p9_put_str(bufp, version, &fc->params.tversion.version);
 547
 548         if (buf_check_overflow(bufp)) {
 549                 kfree(fc);
 550                 fc = ERR_PTR(-ENOMEM);
 551         }
 552 error:
 553         return fc;
 554 }
 555 EXPORT_SYMBOL(p9_create_tversion);
 556
 557 /**
 558  * p9_create_tauth - allocates and creates a T_AUTH request
 559  * @afid: handle to use for authentication protocol
 560  * @uname: user name attempting to authenticate
 561  * @aname: mount specifier for remote server
 562  * @n_uname: numeric id for user attempting to authneticate
 563  * @dotu: 9P2000.u extension flag
 564  *
 565  */
 566
 567 struct p9_fcall *p9_create_tauth(u32 afid, char *uname, char *aname,
 568         u32 n_uname, int dotu)
 569 {
 570         int size;
 571         struct p9_fcall *fc;
 572         struct cbuf buffer;
 573         struct cbuf *bufp = &buffer;
 574
 575         /* afid[4] uname[s] aname[s] */
 576         size = 4 + 2 + 2;
 577         if (uname)
 578                 size += strlen(uname);
 579
 580         if (aname)
 581                 size += strlen(aname);
 582
 583         if (dotu)
 584                 size += 4;      /* n_uname */
 585
 586         fc = p9_create_common(bufp, size, P9_TAUTH);
 587         if (IS_ERR(fc))
 588                 goto error;
 589
 590         p9_put_int32(bufp, afid, &fc->params.tauth.afid);
 591         p9_put_str(bufp, uname, &fc->params.tauth.uname);
 592         p9_put_str(bufp, aname, &fc->params.tauth.aname);
 593         if (dotu)
 594                 p9_put_int32(bufp, n_uname, &fc->params.tauth.n_uname);
 595
 596         if (buf_check_overflow(bufp)) {
 597                 kfree(fc);
 598                 fc = ERR_PTR(-ENOMEM);
 599         }
 600 error:
 601         return fc;
 602 }
 603 EXPORT_SYMBOL(p9_create_tauth);
 604
 605 /**
 606  * p9_create_tattach - allocates and creates a T_ATTACH request
 607  * @fid: handle to use for the new mount point
 608  * @afid: handle to use for authentication protocol
 609  * @uname: user name attempting to attach
 610  * @aname: mount specifier for remote server
 611  * @n_uname: numeric id for user attempting to attach
 612  * @n_uname: numeric id for user attempting to attach
 613  * @dotu: 9P2000.u extension flag
 614  *
 615  */
 616
 617 struct p9_fcall *
 618 p9_create_tattach(u32 fid, u32 afid, char *uname, char *aname,
 619         u32 n_uname, int dotu)
 620 {
 621         int size;
 622         struct p9_fcall *fc;
 623         struct cbuf buffer;
 624         struct cbuf *bufp = &buffer;
 625
 626         /* fid[4] afid[4] uname[s] aname[s] */
 627         size = 4 + 4 + 2 + 2;
 628         if (uname)
 629                 size += strlen(uname);
 630
 631         if (aname)
 632                 size += strlen(aname);
 633
 634         if (dotu)
 635                 size += 4;      /* n_uname */
 636
 637         fc = p9_create_common(bufp, size, P9_TATTACH);
 638         if (IS_ERR(fc))
 639                 goto error;
 640
 641         p9_put_int32(bufp, fid, &fc->params.tattach.fid);
 642         p9_put_int32(bufp, afid, &fc->params.tattach.afid);
 643         p9_put_str(bufp, uname, &fc->params.tattach.uname);
 644         p9_put_str(bufp, aname, &fc->params.tattach.aname);
 645         if (dotu)
 646                 p9_put_int32(bufp, n_uname, &fc->params.tattach.n_uname);
 647
 648 error:
 649         return fc;
 650 }
 651 EXPORT_SYMBOL(p9_create_tattach);
 652
 653 /**
 654  * p9_create_tflush - allocates and creates a T_FLUSH request
 655  * @oldtag: tag id for the transaction we are attempting to cancel
 656  *
 657  */
 658
 659 struct p9_fcall *p9_create_tflush(u16 oldtag)
 660 {
 661         int size;
 662         struct p9_fcall *fc;
 663         struct cbuf buffer;
 664         struct cbuf *bufp = &buffer;
 665
 666         size = 2;               /* oldtag[2] */
 667         fc = p9_create_common(bufp, size, P9_TFLUSH);
 668         if (IS_ERR(fc))
 669                 goto error;
 670
 671         p9_put_int16(bufp, oldtag, &fc->params.tflush.oldtag);
 672
 673         if (buf_check_overflow(bufp)) {
 674                 kfree(fc);
 675                 fc = ERR_PTR(-ENOMEM);
 676         }
 677 error:
 678         return fc;
 679 }
 680 EXPORT_SYMBOL(p9_create_tflush);
 681
 682 /**
 683  * p9_create_twalk - allocates and creates a T_FLUSH request
 684  * @fid: handle we are traversing from
 685  * @newfid: a new handle for this transaction
 686  * @nwname: number of path elements to traverse
 687  * @wnames: array of path elements
 688  *
 689  */
 690
 691 struct p9_fcall *p9_create_twalk(u32 fid, u32 newfid, u16 nwname,
 692                                      char **wnames)
 693 {
 694         int i, size;
 695         struct p9_fcall *fc;
 696         struct cbuf buffer;
 697         struct cbuf *bufp = &buffer;
 698
 699         if (nwname > P9_MAXWELEM) {
 700                 P9_DPRINTK(P9_DEBUG_ERROR, "nwname > %d\n", P9_MAXWELEM);
 701                 return NULL;
 702         }
 703
 704         size = 4 + 4 + 2;       /* fid[4] newfid[4] nwname[2] ... */
 705         for (i = 0; i < nwname; i++) {
 706                 size += 2 + strlen(wnames[i]);  /* wname[s] */
 707         }
 708
 709         fc = p9_create_common(bufp, size, P9_TWALK);
 710         if (IS_ERR(fc))
 711                 goto error;
 712
 713         p9_put_int32(bufp, fid, &fc->params.twalk.fid);
 714         p9_put_int32(bufp, newfid, &fc->params.twalk.newfid);
 715         p9_put_int16(bufp, nwname, &fc->params.twalk.nwname);
 716         for (i = 0; i < nwname; i++) {
 717                 p9_put_str(bufp, wnames[i], &fc->params.twalk.wnames[i]);
 718         }
 719
 720         if (buf_check_overflow(bufp)) {
 721                 kfree(fc);
 722                 fc = ERR_PTR(-ENOMEM);
 723         }
 724 error:
 725         return fc;
 726 }
 727 EXPORT_SYMBOL(p9_create_twalk);
 728
 729 /**
 730  * p9_create_topen - allocates and creates a T_OPEN request
 731  * @fid: handle we are trying to open
 732  * @mode: what mode we are trying to open the file in
 733  *
 734  */
 735
 736 struct p9_fcall *p9_create_topen(u32 fid, u8 mode)
 737 {
 738         int size;
 739         struct p9_fcall *fc;
 740         struct cbuf buffer;
 741         struct cbuf *bufp = &buffer;
 742
 743         size = 4 + 1;           /* fid[4] mode[1] */
 744         fc = p9_create_common(bufp, size, P9_TOPEN);
 745         if (IS_ERR(fc))
 746                 goto error;
 747
 748         p9_put_int32(bufp, fid, &fc->params.topen.fid);
 749         p9_put_int8(bufp, mode, &fc->params.topen.mode);
 750
 751         if (buf_check_overflow(bufp)) {
 752                 kfree(fc);
 753                 fc = ERR_PTR(-ENOMEM);
 754         }
 755 error:
 756         return fc;
 757 }
 758 EXPORT_SYMBOL(p9_create_topen);
 759
 760 /**
 761  * p9_create_tcreate - allocates and creates a T_CREATE request
 762  * @fid: handle of directory we are trying to create in
 763  * @name: name of the file we are trying to create
 764  * @perm: permissions for the file we are trying to create
 765  * @mode: what mode we are trying to open the file in
 766  * @extension: 9p2000.u extension string (for special files)
 767  * @dotu: 9p2000.u enabled flag
 768  *
 769  * Note: Plan 9 create semantics include opening the resulting file
 770  * which is why mode is included.
 771  */
 772
 773 struct p9_fcall *p9_create_tcreate(u32 fid, char *name, u32 perm, u8 mode,
 774         char *extension, int dotu)
 775 {
 776         int size;
 777         struct p9_fcall *fc;
 778         struct cbuf buffer;
 779         struct cbuf *bufp = &buffer;
 780
 781         /* fid[4] name[s] perm[4] mode[1] */
 782         size = 4 + 2 + strlen(name) + 4 + 1;
 783         if (dotu) {
 784                 size += 2 +                     /* extension[s] */
 785                     (extension == NULL ? 0 : strlen(extension));
 786         }
 787
 788         fc = p9_create_common(bufp, size, P9_TCREATE);
 789         if (IS_ERR(fc))
 790                 goto error;
 791
 792         p9_put_int32(bufp, fid, &fc->params.tcreate.fid);
 793         p9_put_str(bufp, name, &fc->params.tcreate.name);
 794         p9_put_int32(bufp, perm, &fc->params.tcreate.perm);
 795         p9_put_int8(bufp, mode, &fc->params.tcreate.mode);
 796         if (dotu)
 797                 p9_put_str(bufp, extension, &fc->params.tcreate.extension);
 798
 799         if (buf_check_overflow(bufp)) {
 800                 kfree(fc);
 801                 fc = ERR_PTR(-ENOMEM);
 802         }
 803 error:
 804         return fc;
 805 }
 806 EXPORT_SYMBOL(p9_create_tcreate);
 807
 808 /**
 809  * p9_create_tread - allocates and creates a T_READ request
 810  * @fid: handle of the file we are trying to read
 811  * @offset: offset to start reading from
 812  * @count: how many bytes to read
 813  */
 814
 815 struct p9_fcall *p9_create_tread(u32 fid, u64 offset, u32 count)
 816 {
 817         int size;
 818         struct p9_fcall *fc;
 819         struct cbuf buffer;
 820         struct cbuf *bufp = &buffer;
 821
 822         size = 4 + 8 + 4;       /* fid[4] offset[8] count[4] */
 823         fc = p9_create_common(bufp, size, P9_TREAD);
 824         if (IS_ERR(fc))
 825                 goto error;
 826
 827         p9_put_int32(bufp, fid, &fc->params.tread.fid);
 828         p9_put_int64(bufp, offset, &fc->params.tread.offset);
 829         p9_put_int32(bufp, count, &fc->params.tread.count);
 830
 831         if (buf_check_overflow(bufp)) {
 832                 kfree(fc);
 833                 fc = ERR_PTR(-ENOMEM);
 834         }
 835 error:
 836         return fc;
 837 }
 838 EXPORT_SYMBOL(p9_create_tread);
 839
 840 /**
 841  * p9_create_twrite - allocates and creates a T_WRITE request from the kernel
 842  * @fid: handle of the file we are trying to write
 843  * @offset: offset to start writing at
 844  * @count: how many bytes to write
 845  * @data: data to write
 846  *
 847  * This function will create a requst with data buffers from the kernel
 848  * such as the page cache.
 849  */
 850
 851 struct p9_fcall *p9_create_twrite(u32 fid, u64 offset, u32 count,
 852                                       const char *data)
 853 {
 854         int size, err;
 855         struct p9_fcall *fc;
 856         struct cbuf buffer;
 857         struct cbuf *bufp = &buffer;
 858
 859         /* fid[4] offset[8] count[4] data[count] */
 860         size = 4 + 8 + 4 + count;
 861         fc = p9_create_common(bufp, size, P9_TWRITE);
 862         if (IS_ERR(fc))
 863                 goto error;
 864
 865         p9_put_int32(bufp, fid, &fc->params.twrite.fid);
 866         p9_put_int64(bufp, offset, &fc->params.twrite.offset);
 867         p9_put_int32(bufp, count, &fc->params.twrite.count);
 868         err = p9_put_data(bufp, data, count, &fc->params.twrite.data);
 869         if (err) {
 870                 kfree(fc);
 871                 fc = ERR_PTR(err);
 872                 goto error;
 873         }
 874
 875         if (buf_check_overflow(bufp)) {
 876                 kfree(fc);
 877                 fc = ERR_PTR(-ENOMEM);
 878         }
 879 error:
 880         return fc;
 881 }
 882 EXPORT_SYMBOL(p9_create_twrite);
 883
 884 /**
 885  * p9_create_twrite_u - allocates and creates a T_WRITE request from userspace
 886  * @fid: handle of the file we are trying to write
 887  * @offset: offset to start writing at
 888  * @count: how many bytes to write
 889  * @data: data to write
 890  *
 891  * This function will create a request with data buffers from userspace
 892  */
 893
 894 struct p9_fcall *p9_create_twrite_u(u32 fid, u64 offset, u32 count,
 895                                       const char __user *data)
 896 {
 897         int size, err;
 898         struct p9_fcall *fc;
 899         struct cbuf buffer;
 900         struct cbuf *bufp = &buffer;
 901
 902         /* fid[4] offset[8] count[4] data[count] */
 903         size = 4 + 8 + 4 + count;
 904         fc = p9_create_common(bufp, size, P9_TWRITE);
 905         if (IS_ERR(fc))
 906                 goto error;
 907
 908         p9_put_int32(bufp, fid, &fc->params.twrite.fid);
 909         p9_put_int64(bufp, offset, &fc->params.twrite.offset);
 910         p9_put_int32(bufp, count, &fc->params.twrite.count);
 911         err = p9_put_user_data(bufp, data, count, &fc->params.twrite.data);
 912         if (err) {
 913                 kfree(fc);
 914                 fc = ERR_PTR(err);
 915                 goto error;
 916         }
 917
 918         if (buf_check_overflow(bufp)) {
 919                 kfree(fc);
 920                 fc = ERR_PTR(-ENOMEM);
 921         }
 922 error:
 923         return fc;
 924 }
 925 EXPORT_SYMBOL(p9_create_twrite_u);
 926
 927 /**
 928  * p9_create_tclunk - allocate a request to forget about a file handle
 929  * @fid: handle of the file we closing or forgetting about
 930  *
 931  * clunk is used both to close open files and to discard transient handles
 932  * which may be created during meta-data operations and hierarchy traversal.
 933  */
 934
 935 struct p9_fcall *p9_create_tclunk(u32 fid)
 936 {
 937         int size;
 938         struct p9_fcall *fc;
 939         struct cbuf buffer;
 940         struct cbuf *bufp = &buffer;
 941
 942         size = 4;               /* fid[4] */
 943         fc = p9_create_common(bufp, size, P9_TCLUNK);
 944         if (IS_ERR(fc))
 945                 goto error;
 946
 947         p9_put_int32(bufp, fid, &fc->params.tclunk.fid);
 948
 949         if (buf_check_overflow(bufp)) {
 950                 kfree(fc);
 951                 fc = ERR_PTR(-ENOMEM);
 952         }
 953 error:
 954         return fc;
 955 }
 956 EXPORT_SYMBOL(p9_create_tclunk);
 957
 958 /**
 959  * p9_create_tremove - allocate and create a request to remove a file
 960  * @fid: handle of the file or directory we are removing
 961  *
 962  */
 963
 964 struct p9_fcall *p9_create_tremove(u32 fid)
 965 {
 966         int size;
 967         struct p9_fcall *fc;
 968         struct cbuf buffer;
 969         struct cbuf *bufp = &buffer;
 970
 971         size = 4;               /* fid[4] */
 972         fc = p9_create_common(bufp, size, P9_TREMOVE);
 973         if (IS_ERR(fc))
 974                 goto error;
 975
 976         p9_put_int32(bufp, fid, &fc->params.tremove.fid);
 977
 978         if (buf_check_overflow(bufp)) {
 979                 kfree(fc);
 980                 fc = ERR_PTR(-ENOMEM);
 981         }
 982 error:
 983         return fc;
 984 }
 985 EXPORT_SYMBOL(p9_create_tremove);
 986
 987 /**
 988  * p9_create_tstat - allocate and populate a request for attributes
 989  * @fid: handle of the file or directory we are trying to get the attributes of
 990  *
 991  */
 992
 993 struct p9_fcall *p9_create_tstat(u32 fid)
 994 {
 995         int size;
 996         struct p9_fcall *fc;
 997         struct cbuf buffer;
 998         struct cbuf *bufp = &buffer;
 999
1000         size = 4;               /* fid[4] */
1001         fc = p9_create_common(bufp, size, P9_TSTAT);
1002         if (IS_ERR(fc))
1003                 goto error;
1004
1005         p9_put_int32(bufp, fid, &fc->params.tstat.fid);
1006
1007         if (buf_check_overflow(bufp)) {
1008                 kfree(fc);
1009                 fc = ERR_PTR(-ENOMEM);
1010         }
1011 error:
1012         return fc;
1013 }
1014 EXPORT_SYMBOL(p9_create_tstat);
1015
1016 /**
1017  * p9_create_tstat - allocate and populate a request to change attributes
1018  * @fid: handle of the file or directory we are trying to change
1019  * @wstat: &p9_stat structure with attributes we wish to set
1020  * @dotu: 9p2000.u enabled flag
1021  *
1022  */
1023
1024 struct p9_fcall *p9_create_twstat(u32 fid, struct p9_wstat *wstat,
1025                                       int dotu)
1026 {
1027         int size, statsz;
1028         struct p9_fcall *fc;
1029         struct cbuf buffer;
1030         struct cbuf *bufp = &buffer;
1031
1032         statsz = p9_size_wstat(wstat, dotu);
1033         size = 4 + 2 + 2 + statsz;      /* fid[4] stat[n] */
1034         fc = p9_create_common(bufp, size, P9_TWSTAT);
1035         if (IS_ERR(fc))
1036                 goto error;
1037
1038         p9_put_int32(bufp, fid, &fc->params.twstat.fid);
1039         buf_put_int16(bufp, statsz + 2);
1040         p9_put_wstat(bufp, wstat, &fc->params.twstat.stat, statsz, dotu);
1041
1042         if (buf_check_overflow(bufp)) {
1043                 kfree(fc);
1044                 fc = ERR_PTR(-ENOMEM);
1045         }
1046 error:
1047         return fc;
1048 }
1049 EXPORT_SYMBOL(p9_create_twstat);
1050