9p: transport API reorganization
[safe/jmp/linux-2.6] / fs / 9p / v9fs.c
index 68f82be..9b0f022 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/idr.h>
 #include <net/9p/9p.h>
 #include <net/9p/transport.h>
-#include <net/9p/conn.h>
 #include <net/9p/client.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_dfltuid, Opt_dfltgid, 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 = {
        {Opt_debug, "debug=%x"},
-       {Opt_msize, "msize=%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}
 };
 
@@ -120,30 +78,30 @@ static match_table_t tokens = {
 
 static void v9fs_parse_options(struct v9fs_session_info *v9ses)
 {
-       char *options = v9ses->options;
+       char *options;
        substring_t args[MAX_OPT_ARGS];
        char *p;
-       int option;
+       int option = 0;
+       char *s, *e;
        int ret;
 
        /* 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)
+       if (!v9ses->options)
                return;
 
+       options = kstrdup(v9ses->options, GFP_KERNEL);
        while ((p = strsep(&options, ",")) != NULL) {
                int token;
                if (!*p)
                        continue;
                token = match_token(p, tokens, args);
                if (token < Opt_uname) {
-                       if ((ret = match_int(&args[0], &option)) < 0) {
+                       ret = match_int(&args[0], &option);
+                       if (ret < 0) {
                                P9_DPRINTK(P9_DEBUG_ERROR,
                                        "integer field, but no integer?\n");
                                continue;
@@ -156,9 +114,7 @@ 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_dfltuid:
                        v9ses->dfltuid = option;
                        break;
@@ -168,17 +124,11 @@ static void v9fs_parse_options(struct v9fs_session_info *v9ses)
                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_strcpy(v9ses->uname, &args[0]);
                        break;
                case Opt_remotename:
-                       match_strcpy(v9ses->remotename, &args[0]);
-                       break;
-               case Opt_legacy:
-                       v9ses->flags &= ~V9FS_EXTENDED;
+                       match_strcpy(v9ses->aname, &args[0]);
                        break;
                case Opt_nodevmap:
                        v9ses->nodev = 1;
@@ -186,10 +136,28 @@ 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]);
+                       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_strtol(s, &e, 10);
+                               if (*e != '\0')
+                                       v9ses->uid = ~0;
+                       }
+                       kfree(s);
+                       break;
+
                default:
                        continue;
                }
        }
+       kfree(options);
 }
 
 /**
@@ -204,49 +172,28 @@ 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;
 
-       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");
-               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, v9ses->options);
 
        if (IS_ERR(v9ses->clnt)) {
                retval = PTR_ERR(v9ses->clnt);
@@ -255,8 +202,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;
+
+       /* 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;
@@ -264,6 +225,11 @@ 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:
@@ -284,8 +250,8 @@ void v9fs_session_close(struct v9fs_session_info *v9ses)
                v9ses->clnt = NULL;
        }
 
-       __putname(v9ses->name);
-       __putname(v9ses->remotename);
+       __putname(v9ses->uname);
+       __putname(v9ses->aname);
        kfree(v9ses->options);
 }