URL https://opencores.org/ocsvn/or1k_soc_on_altera_embedded_dev_kit/or1k_soc_on_altera_embedded_dev_kit/trunk

Subversion Repositories or1k_soc_on_altera_embedded_dev_kit

[/] [or1k_soc_on_altera_embedded_dev_kit/] [trunk/] [linux-2.6/] [linux-2.6.24/] [net/] [9p/] [trans_fd.c] - Blame information for rev 3

Details | Compare with Previous | View Log


/*
 * linux/fs/9p/trans_fd.c
 *
 * Fd transport layer.  Includes deprecated socket layer.
 *
 *  Copyright (C) 2006 by Russ Cox <rsc@swtch.com>
 *  Copyright (C) 2004-2005 by Latchesar Ionkov <lucho@ionkov.net>
 *  Copyright (C) 2004-2007 by Eric Van Hensbergen <ericvh@gmail.com>
 *  Copyright (C) 1997-2002 by Ron Minnich <rminnich@sarnoff.com>
 *
 *  This program is free software; you can redistribute it and/or modify
 *  it under the terms of the GNU General Public License version 2
 *  as published by the Free Software Foundation.
 *
 *  This program is distributed in the hope that it will be useful,
 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 *  GNU General Public License for more details.
 *
 *  You should have received a copy of the GNU General Public License
 *  along with this program; if not, write to:
 *  Free Software Foundation
 *  51 Franklin Street, Fifth Floor
 *  Boston, MA  02111-1301  USA
 *
 */
 
#include <linux/in.h>
#include <linux/module.h>
#include <linux/net.h>
#include <linux/ipv6.h>
#include <linux/errno.h>
#include <linux/kernel.h>
#include <linux/un.h>
#include <linux/uaccess.h>
#include <linux/inet.h>
#include <linux/idr.h>
#include <linux/file.h>
#include <linux/parser.h>
#include <net/9p/9p.h>
#include <net/9p/transport.h>
 
#define P9_PORT 564
#define MAX_SOCK_BUF (64*1024)
 
 
struct p9_fd_opts {
        int rfd;
        int wfd;
        u16 port;
};
 
struct p9_trans_fd {
        struct file *rd;
        struct file *wr;
};
 
/*
  * Option Parsing (code inspired by NFS code)
  *  - a little lazy - parse all fd-transport options
  */
 
enum {
        /* Options that take integer arguments */
        Opt_port, Opt_rfdno, Opt_wfdno, Opt_err,
};
 
static match_table_t tokens = {
        {Opt_port, "port=%u"},
        {Opt_rfdno, "rfdno=%u"},
        {Opt_wfdno, "wfdno=%u"},
        {Opt_err, NULL},
};
 
/**
 * v9fs_parse_options - parse mount options into session structure
 * @options: options string passed from mount
 * @v9ses: existing v9fs session information
 *
 */
 
static void parse_opts(char *options, struct p9_fd_opts *opts)
{
        char *p;
        substring_t args[MAX_OPT_ARGS];
        int option;
        int ret;
 
        opts->port = P9_PORT;
        opts->rfd = ~0;
        opts->wfd = ~0;
 
        if (!options)
                return;
 
        while ((p = strsep(&options, ",")) != NULL) {
                int token;
                if (!*p)
                        continue;
                token = match_token(p, tokens, args);
                ret = match_int(&args[0], &option);
                if (ret < 0) {
                        P9_DPRINTK(P9_DEBUG_ERROR,
                         "integer field, but no integer?\n");
                        continue;
                }
                switch (token) {
                case Opt_port:
                        opts->port = option;
                        break;
                case Opt_rfdno:
                        opts->rfd = option;
                        break;
                case Opt_wfdno:
                        opts->wfd = option;
                        break;
                default:
                        continue;
                }
        }
}
 
static int p9_fd_open(struct p9_trans *trans, int rfd, int wfd)
{
        struct p9_trans_fd *ts = kmalloc(sizeof(struct p9_trans_fd),
                                           GFP_KERNEL);
        if (!ts)
                return -ENOMEM;
 
        ts->rd = fget(rfd);
        ts->wr = fget(wfd);
        if (!ts->rd || !ts->wr) {
                if (ts->rd)
                        fput(ts->rd);
                if (ts->wr)
                        fput(ts->wr);
                kfree(ts);
                return -EIO;
        }
 
        trans->priv = ts;
        trans->status = Connected;
 
        return 0;
}
 
static int p9_socket_open(struct p9_trans *trans, struct socket *csocket)
{
        int fd, ret;
 
        csocket->sk->sk_allocation = GFP_NOIO;
        fd = sock_map_fd(csocket);
        if (fd < 0) {
                P9_EPRINTK(KERN_ERR, "p9_socket_open: failed to map fd\n");
                return fd;
        }
 
        ret = p9_fd_open(trans, fd, fd);
        if (ret < 0) {
                P9_EPRINTK(KERN_ERR, "p9_socket_open: failed to open fd\n");
                sockfd_put(csocket);
                return ret;
        }
 
        ((struct p9_trans_fd *)trans->priv)->rd->f_flags |= O_NONBLOCK;
 
        return 0;
}
 
/**
 * p9_fd_read- read from a fd
 * @v9ses: session information
 * @v: buffer to receive data into
 * @len: size of receive buffer
 *
 */
static int p9_fd_read(struct p9_trans *trans, void *v, int len)
{
        int ret;
        struct p9_trans_fd *ts = NULL;
 
        if (trans && trans->status != Disconnected)
                ts = trans->priv;
 
        if (!ts)
                return -EREMOTEIO;
 
        if (!(ts->rd->f_flags & O_NONBLOCK))
                P9_DPRINTK(P9_DEBUG_ERROR, "blocking read ...\n");
 
        ret = kernel_read(ts->rd, ts->rd->f_pos, v, len);
        if (ret <= 0 && ret != -ERESTARTSYS && ret != -EAGAIN)
                trans->status = Disconnected;
        return ret;
}
 
/**
 * p9_fd_write - write to a socket
 * @v9ses: session information
 * @v: buffer to send data from
 * @len: size of send buffer
 *
 */
static int p9_fd_write(struct p9_trans *trans, void *v, int len)
{
        int ret;
        mm_segment_t oldfs;
        struct p9_trans_fd *ts = NULL;
 
        if (trans && trans->status != Disconnected)
                ts = trans->priv;
 
        if (!ts)
                return -EREMOTEIO;
 
        if (!(ts->wr->f_flags & O_NONBLOCK))
                P9_DPRINTK(P9_DEBUG_ERROR, "blocking write ...\n");
 
        oldfs = get_fs();
        set_fs(get_ds());
        /* The cast to a user pointer is valid due to the set_fs() */
        ret = vfs_write(ts->wr, (void __user *)v, len, &ts->wr->f_pos);
        set_fs(oldfs);
 
        if (ret <= 0 && ret != -ERESTARTSYS && ret != -EAGAIN)
                trans->status = Disconnected;
        return ret;
}
 
static unsigned int
p9_fd_poll(struct p9_trans *trans, struct poll_table_struct *pt)
{
        int ret, n;
        struct p9_trans_fd *ts = NULL;
        mm_segment_t oldfs;
 
        if (trans && trans->status == Connected)
                ts = trans->priv;
 
        if (!ts)
                return -EREMOTEIO;
 
        if (!ts->rd->f_op || !ts->rd->f_op->poll)
                return -EIO;
 
        if (!ts->wr->f_op || !ts->wr->f_op->poll)
                return -EIO;
 
        oldfs = get_fs();
        set_fs(get_ds());
 
        ret = ts->rd->f_op->poll(ts->rd, pt);
        if (ret < 0)
                goto end;
 
        if (ts->rd != ts->wr) {
                n = ts->wr->f_op->poll(ts->wr, pt);
                if (n < 0) {
                        ret = n;
                        goto end;
                }
                ret = (ret & ~POLLOUT) | (n & ~POLLIN);
        }
 
end:
        set_fs(oldfs);
        return ret;
}
 
/**
 * p9_sock_close - shutdown socket
 * @trans: private socket structure
 *
 */
static void p9_fd_close(struct p9_trans *trans)
{
        struct p9_trans_fd *ts;
 
        if (!trans)
                return;
 
        ts = xchg(&trans->priv, NULL);
 
        if (!ts)
                return;
 
        trans->status = Disconnected;
        if (ts->rd)
                fput(ts->rd);
        if (ts->wr)
                fput(ts->wr);
        kfree(ts);
}
 
static struct p9_trans *p9_trans_create_tcp(const char *addr, char *args)
{
        int err;
        struct p9_trans *trans;
        struct socket *csocket;
        struct sockaddr_in sin_server;
        struct p9_fd_opts opts;
 
        parse_opts(args, &opts);
 
        csocket = NULL;
        trans = kmalloc(sizeof(struct p9_trans), GFP_KERNEL);
        if (!trans)
                return ERR_PTR(-ENOMEM);
 
        trans->write = p9_fd_write;
        trans->read = p9_fd_read;
        trans->close = p9_fd_close;
        trans->poll = p9_fd_poll;
 
        sin_server.sin_family = AF_INET;
        sin_server.sin_addr.s_addr = in_aton(addr);
        sin_server.sin_port = htons(opts.port);
        sock_create_kern(PF_INET, SOCK_STREAM, IPPROTO_TCP, &csocket);
 
        if (!csocket) {
                P9_EPRINTK(KERN_ERR, "p9_trans_tcp: problem creating socket\n");
                err = -EIO;
                goto error;
        }
 
        err = csocket->ops->connect(csocket,
                                    (struct sockaddr *)&sin_server,
                                    sizeof(struct sockaddr_in), 0);
        if (err < 0) {
                P9_EPRINTK(KERN_ERR,
                        "p9_trans_tcp: problem connecting socket to %s\n",
                        addr);
                goto error;
        }
 
        err = p9_socket_open(trans, csocket);
        if (err < 0)
                goto error;
 
        return trans;
 
error:
        if (csocket)
                sock_release(csocket);
 
        kfree(trans);
        return ERR_PTR(err);
}
 
static struct p9_trans *p9_trans_create_unix(const char *addr, char *args)
{
        int err;
        struct socket *csocket;
        struct sockaddr_un sun_server;
        struct p9_trans *trans;
 
        csocket = NULL;
        trans = kmalloc(sizeof(struct p9_trans), GFP_KERNEL);
        if (!trans)
                return ERR_PTR(-ENOMEM);
 
        trans->write = p9_fd_write;
        trans->read = p9_fd_read;
        trans->close = p9_fd_close;
        trans->poll = p9_fd_poll;
 
        if (strlen(addr) > UNIX_PATH_MAX) {
                P9_EPRINTK(KERN_ERR, "p9_trans_unix: address too long: %s\n",
                        addr);
                err = -ENAMETOOLONG;
                goto error;
        }
 
        sun_server.sun_family = PF_UNIX;
        strcpy(sun_server.sun_path, addr);
        sock_create_kern(PF_UNIX, SOCK_STREAM, 0, &csocket);
        err = csocket->ops->connect(csocket, (struct sockaddr *)&sun_server,
                        sizeof(struct sockaddr_un) - 1, 0);
        if (err < 0) {
                P9_EPRINTK(KERN_ERR,
                        "p9_trans_unix: problem connecting socket: %s: %d\n",
                        addr, err);
                goto error;
        }
 
        err = p9_socket_open(trans, csocket);
        if (err < 0)
                goto error;
 
        return trans;
 
error:
        if (csocket)
                sock_release(csocket);
 
        kfree(trans);
        return ERR_PTR(err);
}
 
static struct p9_trans *p9_trans_create_fd(const char *name, char *args)
{
        int err;
        struct p9_trans *trans;
        struct p9_fd_opts opts;
 
        parse_opts(args, &opts);
 
        if (opts.rfd == ~0 || opts.wfd == ~0) {
                printk(KERN_ERR "v9fs: Insufficient options for proto=fd\n");
                return ERR_PTR(-ENOPROTOOPT);
        }
 
        trans = kmalloc(sizeof(struct p9_trans), GFP_KERNEL);
        if (!trans)
                return ERR_PTR(-ENOMEM);
 
        trans->write = p9_fd_write;
        trans->read = p9_fd_read;
        trans->close = p9_fd_close;
        trans->poll = p9_fd_poll;
 
        err = p9_fd_open(trans, opts.rfd, opts.wfd);
        if (err < 0)
                goto error;
 
        return trans;
 
error:
        kfree(trans);
        return ERR_PTR(err);
}
 
static struct p9_trans_module p9_tcp_trans = {
        .name = "tcp",
        .maxsize = MAX_SOCK_BUF,
        .def = 1,
        .create = p9_trans_create_tcp,
};
 
static struct p9_trans_module p9_unix_trans = {
        .name = "unix",
        .maxsize = MAX_SOCK_BUF,
        .def = 0,
        .create = p9_trans_create_unix,
};
 
static struct p9_trans_module p9_fd_trans = {
        .name = "fd",
        .maxsize = MAX_SOCK_BUF,
        .def = 0,
        .create = p9_trans_create_fd,
};
 
static int __init p9_trans_fd_init(void)
{
        v9fs_register_trans(&p9_tcp_trans);
        v9fs_register_trans(&p9_unix_trans);
        v9fs_register_trans(&p9_fd_trans);
 
        return 1;
}
 
static void __exit p9_trans_fd_exit(void) {
        printk(KERN_ERR "Removal of 9p transports not implemented\n");
        BUG();
}
 
module_init(p9_trans_fd_init);
module_exit(p9_trans_fd_exit);
 
MODULE_AUTHOR("Latchesar Ionkov <lucho@ionkov.net>");
MODULE_AUTHOR("Eric Van Hensbergen <ericvh@gmail.com>");
MODULE_LICENSE("GPL");

Browse

Tools

Subversion Repositories or1k_soc_on_altera_embedded_dev_kit

[/] [or1k_soc_on_altera_embedded_dev_kit/] [trunk/] [linux-2.6/] [linux-2.6.24/] [net/] [9p/] [trans_fd.c] - Blame information for rev 3

Line No.	Rev	Author	Line
1	3	xianfeng	`/*`
2			`* linux/fs/9p/trans_fd.c`
3			`*`
4			`* Fd transport layer. Includes deprecated socket layer.`
5			`*`
6			`* Copyright (C) 2006 by Russ Cox <rsc@swtch.com>`
7			`* Copyright (C) 2004-2005 by Latchesar Ionkov <lucho@ionkov.net>`
8			`* Copyright (C) 2004-2007 by Eric Van Hensbergen <ericvh@gmail.com>`
9			`* Copyright (C) 1997-2002 by Ron Minnich <rminnich@sarnoff.com>`
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/in.h>`
29			`#include <linux/module.h>`
30			`#include <linux/net.h>`
31			`#include <linux/ipv6.h>`
32			`#include <linux/errno.h>`
33			`#include <linux/kernel.h>`
34			`#include <linux/un.h>`
35			`#include <linux/uaccess.h>`
36			`#include <linux/inet.h>`
37			`#include <linux/idr.h>`
38			`#include <linux/file.h>`
39			`#include <linux/parser.h>`
40			`#include <net/9p/9p.h>`
41			`#include <net/9p/transport.h>`
42
43			`#define P9_PORT 564`
44			`#define MAX_SOCK_BUF (64*1024)`
45
46
47			`struct p9_fd_opts {`
48			`int rfd;`
49			`int wfd;`
50			`u16 port;`
51			`};`
52
53			`struct p9_trans_fd {`
54			`struct file *rd;`
55			`struct file *wr;`
56			`};`
57
58			`/*`
59			`* Option Parsing (code inspired by NFS code)`
60			`* - a little lazy - parse all fd-transport options`
61			`*/`
62
63			`enum {`
64			`/* Options that take integer arguments */`
65			`Opt_port, Opt_rfdno, Opt_wfdno, Opt_err,`
66			`};`
67
68			`static match_table_t tokens = {`
69			`{Opt_port, "port=%u"},`
70			`{Opt_rfdno, "rfdno=%u"},`
71			`{Opt_wfdno, "wfdno=%u"},`
72			`{Opt_err, NULL},`
73			`};`
74
75			`/**`
76			`* v9fs_parse_options - parse mount options into session structure`
77			`* @options: options string passed from mount`
78			`* @v9ses: existing v9fs session information`
79			`*`
80			`*/`
81
82			`static void parse_opts(char options, struct p9_fd_opts opts)`
83			`{`
84			`char *p;`
85			`substring_t args[MAX_OPT_ARGS];`
86			`int option;`
87			`int ret;`
88
89			`opts->port = P9_PORT;`
90			`opts->rfd = ~0;`
91			`opts->wfd = ~0;`
92
93			`if (!options)`
94			`return;`
95
96			`while ((p = strsep(&options, ",")) != NULL) {`
97			`int token;`
98			`if (!*p)`
99			`continue;`
100			`token = match_token(p, tokens, args);`
101			`ret = match_int(&args[0], &option);`
102			`if (ret < 0) {`
103			`P9_DPRINTK(P9_DEBUG_ERROR,`
104			`"integer field, but no integer?\n");`
105			`continue;`
106			`}`
107			`switch (token) {`
108			`case Opt_port:`
109			`opts->port = option;`
110			`break;`
111			`case Opt_rfdno:`
112			`opts->rfd = option;`
113			`break;`
114			`case Opt_wfdno:`
115			`opts->wfd = option;`
116			`break;`
117			`default:`
118			`continue;`
119			`}`
120			`}`
121			`}`
122
123			`static int p9_fd_open(struct p9_trans *trans, int rfd, int wfd)`
124			`{`
125			`struct p9_trans_fd *ts = kmalloc(sizeof(struct p9_trans_fd),`
126			`GFP_KERNEL);`
127			`if (!ts)`
128			`return -ENOMEM;`
129
130			`ts->rd = fget(rfd);`
131			`ts->wr = fget(wfd);`
132			`if (!ts->rd \|\| !ts->wr) {`
133			`if (ts->rd)`
134			`fput(ts->rd);`
135			`if (ts->wr)`
136			`fput(ts->wr);`
137			`kfree(ts);`
138			`return -EIO;`
139			`}`
140
141			`trans->priv = ts;`
142			`trans->status = Connected;`
143
144			`return 0;`
145			`}`
146
147			`static int p9_socket_open(struct p9_trans trans, struct socket csocket)`
148			`{`
149			`int fd, ret;`
150
151			`csocket->sk->sk_allocation = GFP_NOIO;`
152			`fd = sock_map_fd(csocket);`
153			`if (fd < 0) {`
154			`P9_EPRINTK(KERN_ERR, "p9_socket_open: failed to map fd\n");`
155			`return fd;`
156			`}`
157
158			`ret = p9_fd_open(trans, fd, fd);`
159			`if (ret < 0) {`
160			`P9_EPRINTK(KERN_ERR, "p9_socket_open: failed to open fd\n");`
161			`sockfd_put(csocket);`
162			`return ret;`
163			`}`
164
165			`((struct p9_trans_fd *)trans->priv)->rd->f_flags \|= O_NONBLOCK;`
166
167			`return 0;`
168			`}`
169
170			`/**`
171			`* p9_fd_read- read from a fd`
172			`* @v9ses: session information`
173			`* @v: buffer to receive data into`
174			`* @len: size of receive buffer`
175			`*`
176			`*/`
177			`static int p9_fd_read(struct p9_trans trans, void v, int len)`
178			`{`
179			`int ret;`
180			`struct p9_trans_fd *ts = NULL;`
181
182			`if (trans && trans->status != Disconnected)`
183			`ts = trans->priv;`
184
185			`if (!ts)`
186			`return -EREMOTEIO;`
187
188			`if (!(ts->rd->f_flags & O_NONBLOCK))`
189			`P9_DPRINTK(P9_DEBUG_ERROR, "blocking read ...\n");`
190
191			`ret = kernel_read(ts->rd, ts->rd->f_pos, v, len);`
192			`if (ret <= 0 && ret != -ERESTARTSYS && ret != -EAGAIN)`
193			`trans->status = Disconnected;`
194			`return ret;`
195			`}`
196
197			`/**`
198			`* p9_fd_write - write to a socket`
199			`* @v9ses: session information`
200			`* @v: buffer to send data from`
201			`* @len: size of send buffer`
202			`*`
203			`*/`
204			`static int p9_fd_write(struct p9_trans trans, void v, int len)`
205			`{`
206			`int ret;`
207			`mm_segment_t oldfs;`
208			`struct p9_trans_fd *ts = NULL;`
209
210			`if (trans && trans->status != Disconnected)`
211			`ts = trans->priv;`
212
213			`if (!ts)`
214			`return -EREMOTEIO;`
215
216			`if (!(ts->wr->f_flags & O_NONBLOCK))`
217			`P9_DPRINTK(P9_DEBUG_ERROR, "blocking write ...\n");`
218
219			`oldfs = get_fs();`
220			`set_fs(get_ds());`
221			`/* The cast to a user pointer is valid due to the set_fs() */`
222			`ret = vfs_write(ts->wr, (void __user *)v, len, &ts->wr->f_pos);`
223			`set_fs(oldfs);`
224
225			`if (ret <= 0 && ret != -ERESTARTSYS && ret != -EAGAIN)`
226			`trans->status = Disconnected;`
227			`return ret;`
228			`}`
229
230			`static unsigned int`
231			`p9_fd_poll(struct p9_trans trans, struct poll_table_struct pt)`
232			`{`
233			`int ret, n;`
234			`struct p9_trans_fd *ts = NULL;`
235			`mm_segment_t oldfs;`
236
237			`if (trans && trans->status == Connected)`
238			`ts = trans->priv;`
239
240			`if (!ts)`
241			`return -EREMOTEIO;`
242
243			`if (!ts->rd->f_op \|\| !ts->rd->f_op->poll)`
244			`return -EIO;`
245
246			`if (!ts->wr->f_op \|\| !ts->wr->f_op->poll)`
247			`return -EIO;`
248
249			`oldfs = get_fs();`
250			`set_fs(get_ds());`
251
252			`ret = ts->rd->f_op->poll(ts->rd, pt);`
253			`if (ret < 0)`
254			`goto end;`
255
256			`if (ts->rd != ts->wr) {`
257			`n = ts->wr->f_op->poll(ts->wr, pt);`
258			`if (n < 0) {`
259			`ret = n;`
260			`goto end;`
261			`}`
262			`ret = (ret & ~POLLOUT) \| (n & ~POLLIN);`
263			`}`
264
265			`end:`
266			`set_fs(oldfs);`
267			`return ret;`
268			`}`
269
270			`/**`
271			`* p9_sock_close - shutdown socket`
272			`* @trans: private socket structure`
273			`*`
274			`*/`
275			`static void p9_fd_close(struct p9_trans *trans)`
276			`{`
277			`struct p9_trans_fd *ts;`
278
279			`if (!trans)`
280			`return;`
281
282			`ts = xchg(&trans->priv, NULL);`
283
284			`if (!ts)`
285			`return;`
286
287			`trans->status = Disconnected;`
288			`if (ts->rd)`
289			`fput(ts->rd);`
290			`if (ts->wr)`
291			`fput(ts->wr);`
292			`kfree(ts);`
293			`}`
294
295			`static struct p9_trans p9_trans_create_tcp(const char addr, char *args)`
296			`{`
297			`int err;`
298			`struct p9_trans *trans;`
299			`struct socket *csocket;`
300			`struct sockaddr_in sin_server;`
301			`struct p9_fd_opts opts;`
302
303			`parse_opts(args, &opts);`
304
305			`csocket = NULL;`
306			`trans = kmalloc(sizeof(struct p9_trans), GFP_KERNEL);`
307			`if (!trans)`
308			`return ERR_PTR(-ENOMEM);`
309
310			`trans->write = p9_fd_write;`
311			`trans->read = p9_fd_read;`
312			`trans->close = p9_fd_close;`
313			`trans->poll = p9_fd_poll;`
314
315			`sin_server.sin_family = AF_INET;`
316			`sin_server.sin_addr.s_addr = in_aton(addr);`
317			`sin_server.sin_port = htons(opts.port);`
318			`sock_create_kern(PF_INET, SOCK_STREAM, IPPROTO_TCP, &csocket);`
319
320			`if (!csocket) {`
321			`P9_EPRINTK(KERN_ERR, "p9_trans_tcp: problem creating socket\n");`
322			`err = -EIO;`
323			`goto error;`
324			`}`
325
326			`err = csocket->ops->connect(csocket,`
327			`(struct sockaddr *)&sin_server,`
328			`sizeof(struct sockaddr_in), 0);`
329			`if (err < 0) {`
330			`P9_EPRINTK(KERN_ERR,`
331			`"p9_trans_tcp: problem connecting socket to %s\n",`
332			`addr);`
333			`goto error;`
334			`}`
335
336			`err = p9_socket_open(trans, csocket);`
337			`if (err < 0)`
338			`goto error;`
339
340			`return trans;`
341
342			`error:`
343			`if (csocket)`
344			`sock_release(csocket);`
345
346			`kfree(trans);`
347			`return ERR_PTR(err);`
348			`}`
349
350			`static struct p9_trans p9_trans_create_unix(const char addr, char *args)`
351			`{`
352			`int err;`
353			`struct socket *csocket;`
354			`struct sockaddr_un sun_server;`
355			`struct p9_trans *trans;`
356
357			`csocket = NULL;`
358			`trans = kmalloc(sizeof(struct p9_trans), GFP_KERNEL);`
359			`if (!trans)`
360			`return ERR_PTR(-ENOMEM);`
361
362			`trans->write = p9_fd_write;`
363			`trans->read = p9_fd_read;`
364			`trans->close = p9_fd_close;`
365			`trans->poll = p9_fd_poll;`
366
367			`if (strlen(addr) > UNIX_PATH_MAX) {`
368			`P9_EPRINTK(KERN_ERR, "p9_trans_unix: address too long: %s\n",`
369			`addr);`
370			`err = -ENAMETOOLONG;`
371			`goto error;`
372			`}`
373
374			`sun_server.sun_family = PF_UNIX;`
375			`strcpy(sun_server.sun_path, addr);`
376			`sock_create_kern(PF_UNIX, SOCK_STREAM, 0, &csocket);`
377			`err = csocket->ops->connect(csocket, (struct sockaddr *)&sun_server,`
378			`sizeof(struct sockaddr_un) - 1, 0);`
379			`if (err < 0) {`
380			`P9_EPRINTK(KERN_ERR,`
381			`"p9_trans_unix: problem connecting socket: %s: %d\n",`
382			`addr, err);`
383			`goto error;`
384			`}`
385
386			`err = p9_socket_open(trans, csocket);`
387			`if (err < 0)`
388			`goto error;`
389
390			`return trans;`
391
392			`error:`
393			`if (csocket)`
394			`sock_release(csocket);`
395
396			`kfree(trans);`
397			`return ERR_PTR(err);`
398			`}`
399
400			`static struct p9_trans p9_trans_create_fd(const char name, char *args)`
401			`{`
402			`int err;`
403			`struct p9_trans *trans;`
404			`struct p9_fd_opts opts;`
405
406			`parse_opts(args, &opts);`
407
408			`if (opts.rfd == ~0 \|\| opts.wfd == ~0) {`
409			`printk(KERN_ERR "v9fs: Insufficient options for proto=fd\n");`
410			`return ERR_PTR(-ENOPROTOOPT);`
411			`}`
412
413			`trans = kmalloc(sizeof(struct p9_trans), GFP_KERNEL);`
414			`if (!trans)`
415			`return ERR_PTR(-ENOMEM);`
416
417			`trans->write = p9_fd_write;`
418			`trans->read = p9_fd_read;`
419			`trans->close = p9_fd_close;`
420			`trans->poll = p9_fd_poll;`
421
422			`err = p9_fd_open(trans, opts.rfd, opts.wfd);`
423			`if (err < 0)`
424			`goto error;`
425
426			`return trans;`
427
428			`error:`
429			`kfree(trans);`
430			`return ERR_PTR(err);`
431			`}`
432
433			`static struct p9_trans_module p9_tcp_trans = {`
434			`.name = "tcp",`
435			`.maxsize = MAX_SOCK_BUF,`
436			`.def = 1,`
437			`.create = p9_trans_create_tcp,`
438			`};`
439
440			`static struct p9_trans_module p9_unix_trans = {`
441			`.name = "unix",`
442			`.maxsize = MAX_SOCK_BUF,`
443			`.def = 0,`
444			`.create = p9_trans_create_unix,`
445			`};`
446
447			`static struct p9_trans_module p9_fd_trans = {`
448			`.name = "fd",`
449			`.maxsize = MAX_SOCK_BUF,`
450			`.def = 0,`
451			`.create = p9_trans_create_fd,`
452			`};`
453
454			`static int __init p9_trans_fd_init(void)`
455			`{`
456			`v9fs_register_trans(&p9_tcp_trans);`
457			`v9fs_register_trans(&p9_unix_trans);`
458			`v9fs_register_trans(&p9_fd_trans);`
459
460			`return 1;`
461			`}`
462
463			`static void __exit p9_trans_fd_exit(void) {`
464			`printk(KERN_ERR "Removal of 9p transports not implemented\n");`
465			`BUG();`
466			`}`
467
468			`module_init(p9_trans_fd_init);`
469			`module_exit(p9_trans_fd_exit);`
470
471			`MODULE_AUTHOR("Latchesar Ionkov <lucho@ionkov.net>");`
472			`MODULE_AUTHOR("Eric Van Hensbergen <ericvh@gmail.com>");`
473			`MODULE_LICENSE("GPL");`