Merge branch 'linus' into core/rcu
[safe/jmp/linux-2.6] / fs / 9p / v9fs.c
index 8ac2467..f7003cf 100644 (file)
@@ -3,7 +3,7 @@
  *
  *  This file contains functions assisting in mapping VFS to 9P2000
  *
- *  Copyright (C) 2004 by Eric Van Hensbergen <ericvh@gmail.com>
+ *  Copyright (C) 2004-2008 by Eric Van Hensbergen <ericvh@gmail.com>
  *  Copyright (C) 2002 by Ron Minnich <rminnich@lanl.gov>
  *
  *  This program is free software; you can redistribute it and/or modify
 #include <linux/parser.h>
 #include <linux/idr.h>
 #include <net/9p/9p.h>
-#include <net/9p/transport.h>
-#include <net/9p/conn.h>
 #include <net/9p/client.h>
+#include <net/9p/transport.h>
 #include "v9fs.h"
 #include "v9fs_vfs.h"
 
 /*
- * Dynamic Transport Registration Routines
- *
- */
-
-static LIST_HEAD(v9fs_trans_list);
-static struct p9_trans_module *v9fs_default_trans;
-
-/**
- * v9fs_register_trans - register a new transport with 9p
- * @m - structure describing the transport module and entry points
- *
- */
-void v9fs_register_trans(struct p9_trans_module *m)
-{
-       list_add_tail(&m->list, &v9fs_trans_list);
-       if (m->def)
-               v9fs_default_trans = m;
-}
-EXPORT_SYMBOL(v9fs_register_trans);
-
-/**
- * v9fs_match_trans - match transport versus registered transports
- * @arg: string identifying transport
- *
- */
-static struct p9_trans_module *v9fs_match_trans(const substring_t *name)
-{
-       struct list_head *p;
-       struct p9_trans_module *t = NULL;
-
-       list_for_each(p, &v9fs_trans_list) {
-               t = list_entry(p, struct p9_trans_module, list);
-               if (strncmp(t->name, name->from, name->to-name->from) == 0) {
-                       P9_DPRINTK(P9_DEBUG_TRANS, "trans=%s\n", t->name);
-                       break;
-               }
-       }
-       return t;
-}
-
-/*
   * Option Parsing (code inspired by NFS code)
   *  NOTE: each transport will parse its own options
   */
 
 enum {
        /* Options that take integer arguments */
-       Opt_debug, Opt_msize, Opt_uid, Opt_gid, Opt_afid,
+       Opt_debug, Opt_dfltuid, Opt_dfltgid, Opt_afid,
        /* String options */
        Opt_uname, Opt_remotename, Opt_trans,
        /* Options that take no arguments */
-       Opt_legacy, Opt_nodevmap,
+       Opt_nodevmap,
        /* Cache options */
        Opt_cache_loose,
+       /* Access options */
+       Opt_access,
        /* Error token */
        Opt_err
 };
 
-static match_table_t tokens = {
+static const match_table_t tokens = {
        {Opt_debug, "debug=%x"},
-       {Opt_msize, "msize=%u"},
-       {Opt_uid, "uid=%u"},
-       {Opt_gid, "gid=%u"},
+       {Opt_dfltuid, "dfltuid=%u"},
+       {Opt_dfltgid, "dfltgid=%u"},
        {Opt_afid, "afid=%u"},
        {Opt_uname, "uname=%s"},
        {Opt_remotename, "aname=%s"},
-       {Opt_trans, "trans=%s"},
-       {Opt_legacy, "noextend"},
        {Opt_nodevmap, "nodevmap"},
        {Opt_cache_loose, "cache=loose"},
        {Opt_cache_loose, "loose"},
+       {Opt_access, "access=%s"},
        {Opt_err, NULL}
 };
 
 /**
  * v9fs_parse_options - parse mount options into session structure
- * @options: options string passed from mount
  * @v9ses: existing v9fs session information
  *
+ * Return 0 upon success, -ERRNO upon failure.
  */
 
-static void v9fs_parse_options(struct v9fs_session_info *v9ses)
+static int v9fs_parse_options(struct v9fs_session_info *v9ses, char *opts)
 {
-       char *options = v9ses->options;
+       char *options;
        substring_t args[MAX_OPT_ARGS];
        char *p;
-       int option;
-       int ret;
+       int option = 0;
+       char *s, *e;
+       int ret = 0;
 
        /* setup defaults */
-       v9ses->maxdata = 8192;
-       v9ses->flags = V9FS_EXTENDED;
        v9ses->afid = ~0;
        v9ses->debug = 0;
        v9ses->cache = 0;
-       v9ses->trans = v9fs_default_trans;
 
-       if (!options)
-               return;
+       if (!opts)
+               return 0;
+
+       options = kstrdup(opts, GFP_KERNEL);
+       if (!options) {
+               P9_DPRINTK(P9_DEBUG_ERROR,
+                          "failed to allocate copy of option string\n");
+               return -ENOMEM;
+       }
 
        while ((p = strsep(&options, ",")) != NULL) {
                int token;
@@ -143,9 +106,11 @@ static void v9fs_parse_options(struct v9fs_session_info *v9ses)
                        continue;
                token = match_token(p, tokens, args);
                if (token < Opt_uname) {
-                       if ((ret = match_int(&args[0], &option)) < 0) {
+                       int r = match_int(&args[0], &option);
+                       if (r < 0) {
                                P9_DPRINTK(P9_DEBUG_ERROR,
                                        "integer field, but no integer?\n");
+                               ret = r;
                                continue;
                        }
                }
@@ -156,29 +121,21 @@ static void v9fs_parse_options(struct v9fs_session_info *v9ses)
                        p9_debug_level = option;
 #endif
                        break;
-               case Opt_msize:
-                       v9ses->maxdata = option;
-                       break;
-               case Opt_uid:
-                       v9ses->uid = option;
+
+               case Opt_dfltuid:
+                       v9ses->dfltuid = option;
                        break;
-               case Opt_gid:
-                       v9ses->gid = option;
+               case Opt_dfltgid:
+                       v9ses->dfltgid = option;
                        break;
                case Opt_afid:
                        v9ses->afid = option;
                        break;
-               case Opt_trans:
-                       v9ses->trans = v9fs_match_trans(&args[0]);
-                       break;
                case Opt_uname:
-                       match_strcpy(v9ses->name, &args[0]);
+                       match_strlcpy(v9ses->uname, &args[0], PATH_MAX);
                        break;
                case Opt_remotename:
-                       match_strcpy(v9ses->remotename, &args[0]);
-                       break;
-               case Opt_legacy:
-                       v9ses->flags &= ~V9FS_EXTENDED;
+                       match_strlcpy(v9ses->aname, &args[0], PATH_MAX);
                        break;
                case Opt_nodevmap:
                        v9ses->nodev = 1;
@@ -186,10 +143,36 @@ static void v9fs_parse_options(struct v9fs_session_info *v9ses)
                case Opt_cache_loose:
                        v9ses->cache = CACHE_LOOSE;
                        break;
+
+               case Opt_access:
+                       s = match_strdup(&args[0]);
+                       if (!s) {
+                               P9_DPRINTK(P9_DEBUG_ERROR,
+                                          "failed to allocate copy"
+                                          " of option argument\n");
+                               ret = -ENOMEM;
+                               break;
+                       }
+                       v9ses->flags &= ~V9FS_ACCESS_MASK;
+                       if (strcmp(s, "user") == 0)
+                               v9ses->flags |= V9FS_ACCESS_USER;
+                       else if (strcmp(s, "any") == 0)
+                               v9ses->flags |= V9FS_ACCESS_ANY;
+                       else {
+                               v9ses->flags |= V9FS_ACCESS_SINGLE;
+                               v9ses->uid = simple_strtoul(s, &e, 10);
+                               if (*e != '\0')
+                                       v9ses->uid = ~0;
+                       }
+                       kfree(s);
+                       break;
+
                default:
                        continue;
                }
        }
+       kfree(options);
+       return ret;
 }
 
 /**
@@ -204,48 +187,33 @@ struct p9_fid *v9fs_session_init(struct v9fs_session_info *v9ses,
                  const char *dev_name, char *data)
 {
        int retval = -EINVAL;
-       struct p9_trans *trans = NULL;
        struct p9_fid *fid;
+       int rc;
 
-       v9ses->name = __getname();
-       if (!v9ses->name)
+       v9ses->uname = __getname();
+       if (!v9ses->uname)
                return ERR_PTR(-ENOMEM);
 
-       v9ses->remotename = __getname();
-       if (!v9ses->remotename) {
-               __putname(v9ses->name);
+       v9ses->aname = __getname();
+       if (!v9ses->aname) {
+               __putname(v9ses->uname);
                return ERR_PTR(-ENOMEM);
        }
 
-       strcpy(v9ses->name, V9FS_DEFUSER);
-       strcpy(v9ses->remotename, V9FS_DEFANAME);
+       v9ses->flags = V9FS_EXTENDED | V9FS_ACCESS_USER;
+       strcpy(v9ses->uname, V9FS_DEFUSER);
+       strcpy(v9ses->aname, V9FS_DEFANAME);
+       v9ses->uid = ~0;
+       v9ses->dfltuid = V9FS_DEFUID;
+       v9ses->dfltgid = V9FS_DEFGID;
 
-       v9ses->options = kstrdup(data, GFP_KERNEL);
-       v9fs_parse_options(v9ses);
-
-       if ((v9ses->trans == NULL) && !list_empty(&v9fs_trans_list))
-               v9ses->trans = list_first_entry(&v9fs_trans_list,
-                struct p9_trans_module, list);
-
-       if (v9ses->trans == NULL) {
-               retval = -EPROTONOSUPPORT;
-               P9_DPRINTK(P9_DEBUG_ERROR,
-                               "No transport defined or default transport\n");
+       rc = v9fs_parse_options(v9ses, data);
+       if (rc < 0) {
+               retval = rc;
                goto error;
        }
 
-       trans = v9ses->trans->create(dev_name, v9ses->options);
-       if (IS_ERR(trans)) {
-               retval = PTR_ERR(trans);
-               trans = NULL;
-               goto error;
-       }
-       if ((v9ses->maxdata+P9_IOHDRSZ) > v9ses->trans->maxsize)
-               v9ses->maxdata = v9ses->trans->maxsize-P9_IOHDRSZ;
-
-       v9ses->clnt = p9_client_create(trans, v9ses->maxdata+P9_IOHDRSZ,
-               v9fs_extended(v9ses));
-
+       v9ses->clnt = p9_client_create(dev_name, data);
        if (IS_ERR(v9ses->clnt)) {
                retval = PTR_ERR(v9ses->clnt);
                v9ses->clnt = NULL;
@@ -253,8 +221,22 @@ struct p9_fid *v9fs_session_init(struct v9fs_session_info *v9ses,
                goto error;
        }
 
-       fid = p9_client_attach(v9ses->clnt, NULL, v9ses->name,
-                                                       v9ses->remotename);
+       if (!v9ses->clnt->dotu)
+               v9ses->flags &= ~V9FS_EXTENDED;
+
+       v9ses->maxdata = v9ses->clnt->msize - P9_IOHDRSZ;
+
+       /* for legacy mode, fall back to V9FS_ACCESS_ANY */
+       if (!v9fs_extended(v9ses) &&
+               ((v9ses->flags&V9FS_ACCESS_MASK) == V9FS_ACCESS_USER)) {
+
+               v9ses->flags &= ~V9FS_ACCESS_MASK;
+               v9ses->flags |= V9FS_ACCESS_ANY;
+               v9ses->uid = ~0;
+       }
+
+       fid = p9_client_attach(v9ses->clnt, NULL, v9ses->uname, ~0,
+                                                       v9ses->aname);
        if (IS_ERR(fid)) {
                retval = PTR_ERR(fid);
                fid = NULL;
@@ -262,10 +244,14 @@ struct p9_fid *v9fs_session_init(struct v9fs_session_info *v9ses,
                goto error;
        }
 
+       if ((v9ses->flags & V9FS_ACCESS_MASK) == V9FS_ACCESS_SINGLE)
+               fid->uid = v9ses->uid;
+       else
+               fid->uid = ~0;
+
        return fid;
 
 error:
-       v9fs_session_close(v9ses);
        return ERR_PTR(retval);
 }
 
@@ -282,15 +268,17 @@ void v9fs_session_close(struct v9fs_session_info *v9ses)
                v9ses->clnt = NULL;
        }
 
-       __putname(v9ses->name);
-       __putname(v9ses->remotename);
-       kfree(v9ses->options);
+       __putname(v9ses->uname);
+       __putname(v9ses->aname);
 }
 
 /**
- * v9fs_session_cancel - mark transport as disconnected
- *     and cancel all pending requests.
+ * v9fs_session_cancel - terminate a session
+ * @v9ses: session to terminate
+ *
+ * mark transport as disconnected and cancel all pending requests.
  */
+
 void v9fs_session_cancel(struct v9fs_session_info *v9ses) {
        P9_DPRINTK(P9_DEBUG_ERROR, "cancel session %p\n", v9ses);
        p9_client_disconnect(v9ses->clnt);