diff options
author | Eric Van Hensbergen <ericvh@gmail.com> | 2005-09-09 16:04:18 -0400 |
---|---|---|
committer | Linus Torvalds <torvalds@g5.osdl.org> | 2005-09-09 16:57:56 -0400 |
commit | e69e7fe5b0c86b7271045444a3a681136234c659 (patch) | |
tree | 3ced44a52b09e6414501f686a12f77ca09bbd067 /fs | |
parent | 93fa58cb831337fdf5d36b3b913441100a484dae (diff) |
[PATCH] v9fs: VFS file, dentry, and directory operations
This part of the patch contains the VFS file, dentry & directory interfaces.
Signed-off-by: Eric Van Hensbergen <ericvh@gmail.com>
Signed-off-by: Andrew Morton <akpm@osdl.org>
Signed-off-by: Linus Torvalds <torvalds@osdl.org>
Diffstat (limited to 'fs')
-rw-r--r-- | fs/9p/vfs_dentry.c | 126 | ||||
-rw-r--r-- | fs/9p/vfs_dir.c | 226 | ||||
-rw-r--r-- | fs/9p/vfs_file.c | 401 |
3 files changed, 753 insertions, 0 deletions
diff --git a/fs/9p/vfs_dentry.c b/fs/9p/vfs_dentry.c new file mode 100644 index 000000000000..306c96741f81 --- /dev/null +++ b/fs/9p/vfs_dentry.c | |||
@@ -0,0 +1,126 @@ | |||
1 | /* | ||
2 | * linux/fs/9p/vfs_dentry.c | ||
3 | * | ||
4 | * This file contians vfs dentry ops for the 9P2000 protocol. | ||
5 | * | ||
6 | * Copyright (C) 2004 by Eric Van Hensbergen <ericvh@gmail.com> | ||
7 | * Copyright (C) 2002 by Ron Minnich <rminnich@lanl.gov> | ||
8 | * | ||
9 | * This program is free software; you can redistribute it and/or modify | ||
10 | * it under the terms of the GNU General Public License as published by | ||
11 | * the Free Software Foundation; either version 2 of the License, or | ||
12 | * (at your option) any later version. | ||
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/file.h> | ||
31 | #include <linux/pagemap.h> | ||
32 | #include <linux/stat.h> | ||
33 | #include <linux/string.h> | ||
34 | #include <linux/smp_lock.h> | ||
35 | #include <linux/inet.h> | ||
36 | #include <linux/namei.h> | ||
37 | #include <linux/idr.h> | ||
38 | |||
39 | #include "debug.h" | ||
40 | #include "v9fs.h" | ||
41 | #include "9p.h" | ||
42 | #include "v9fs_vfs.h" | ||
43 | #include "conv.h" | ||
44 | #include "fid.h" | ||
45 | |||
46 | /** | ||
47 | * v9fs_dentry_validate - VFS dcache hook to validate cache | ||
48 | * @dentry: dentry that is being validated | ||
49 | * @nd: path data | ||
50 | * | ||
51 | * dcache really shouldn't be used for 9P2000 as at all due to | ||
52 | * potential attached semantics to directory traversal (walk). | ||
53 | * | ||
54 | * FUTURE: look into how to use dcache to allow multi-stage | ||
55 | * walks in Plan 9 & potential for better dcache operation which | ||
56 | * would remain valid for Plan 9 semantics. Older versions | ||
57 | * had validation via stat for those interested. However, since | ||
58 | * stat has the same approximate overhead as walk there really | ||
59 | * is no difference. The only improvement would be from a | ||
60 | * time-decay cache like NFS has and that undermines the | ||
61 | * synchronous nature of 9P2000. | ||
62 | * | ||
63 | */ | ||
64 | |||
65 | static int v9fs_dentry_validate(struct dentry *dentry, struct nameidata *nd) | ||
66 | { | ||
67 | struct dentry *dc = current->fs->pwd; | ||
68 | |||
69 | dprintk(DEBUG_VFS, "dentry: %s (%p)\n", dentry->d_iname, dentry); | ||
70 | if (v9fs_fid_lookup(dentry, FID_OP)) { | ||
71 | dprintk(DEBUG_VFS, "VALID\n"); | ||
72 | return 1; | ||
73 | } | ||
74 | |||
75 | while (dc != NULL) { | ||
76 | if (dc == dentry) { | ||
77 | dprintk(DEBUG_VFS, "VALID\n"); | ||
78 | return 1; | ||
79 | } | ||
80 | if (dc == dc->d_parent) | ||
81 | break; | ||
82 | |||
83 | dc = dc->d_parent; | ||
84 | } | ||
85 | |||
86 | dprintk(DEBUG_VFS, "INVALID\n"); | ||
87 | return 0; | ||
88 | } | ||
89 | |||
90 | /** | ||
91 | * v9fs_dentry_release - called when dentry is going to be freed | ||
92 | * @dentry: dentry that is being release | ||
93 | * | ||
94 | */ | ||
95 | |||
96 | void v9fs_dentry_release(struct dentry *dentry) | ||
97 | { | ||
98 | dprintk(DEBUG_VFS, " dentry: %s (%p)\n", dentry->d_iname, dentry); | ||
99 | |||
100 | if (dentry->d_fsdata != NULL) { | ||
101 | struct list_head *fid_list = dentry->d_fsdata; | ||
102 | struct v9fs_fid *temp = NULL; | ||
103 | struct v9fs_fid *current_fid = NULL; | ||
104 | struct v9fs_fcall *fcall = NULL; | ||
105 | |||
106 | list_for_each_entry_safe(current_fid, temp, fid_list, list) { | ||
107 | if (v9fs_t_clunk | ||
108 | (current_fid->v9ses, current_fid->fid, &fcall)) | ||
109 | dprintk(DEBUG_ERROR, "clunk failed: %s\n", | ||
110 | FCALL_ERROR(fcall)); | ||
111 | |||
112 | v9fs_put_idpool(current_fid->fid, | ||
113 | ¤t_fid->v9ses->fidpool); | ||
114 | |||
115 | kfree(fcall); | ||
116 | v9fs_fid_destroy(current_fid); | ||
117 | } | ||
118 | |||
119 | kfree(dentry->d_fsdata); /* free the list_head */ | ||
120 | } | ||
121 | } | ||
122 | |||
123 | struct dentry_operations v9fs_dentry_operations = { | ||
124 | .d_revalidate = v9fs_dentry_validate, | ||
125 | .d_release = v9fs_dentry_release, | ||
126 | }; | ||
diff --git a/fs/9p/vfs_dir.c b/fs/9p/vfs_dir.c new file mode 100644 index 000000000000..c478a7384186 --- /dev/null +++ b/fs/9p/vfs_dir.c | |||
@@ -0,0 +1,226 @@ | |||
1 | /* | ||
2 | * linux/fs/9p/vfs_dir.c | ||
3 | * | ||
4 | * This file contains vfs directory ops for the 9P2000 protocol. | ||
5 | * | ||
6 | * Copyright (C) 2004 by Eric Van Hensbergen <ericvh@gmail.com> | ||
7 | * Copyright (C) 2002 by Ron Minnich <rminnich@lanl.gov> | ||
8 | * | ||
9 | * This program is free software; you can redistribute it and/or modify | ||
10 | * it under the terms of the GNU General Public License as published by | ||
11 | * the Free Software Foundation; either version 2 of the License, or | ||
12 | * (at your option) any later version. | ||
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/file.h> | ||
31 | #include <linux/stat.h> | ||
32 | #include <linux/string.h> | ||
33 | #include <linux/smp_lock.h> | ||
34 | #include <linux/inet.h> | ||
35 | #include <linux/idr.h> | ||
36 | |||
37 | #include "debug.h" | ||
38 | #include "v9fs.h" | ||
39 | #include "9p.h" | ||
40 | #include "v9fs_vfs.h" | ||
41 | #include "conv.h" | ||
42 | #include "fid.h" | ||
43 | |||
44 | /** | ||
45 | * dt_type - return file type | ||
46 | * @mistat: mistat structure | ||
47 | * | ||
48 | */ | ||
49 | |||
50 | static inline int dt_type(struct v9fs_stat *mistat) | ||
51 | { | ||
52 | unsigned long perm = mistat->mode; | ||
53 | int rettype = DT_REG; | ||
54 | |||
55 | if (perm & V9FS_DMDIR) | ||
56 | rettype = DT_DIR; | ||
57 | if (perm & V9FS_DMSYMLINK) | ||
58 | rettype = DT_LNK; | ||
59 | |||
60 | return rettype; | ||
61 | } | ||
62 | |||
63 | /** | ||
64 | * v9fs_dir_readdir - read a directory | ||
65 | * @filep: opened file structure | ||
66 | * @dirent: directory structure ??? | ||
67 | * @filldir: function to populate directory structure ??? | ||
68 | * | ||
69 | */ | ||
70 | |||
71 | static int v9fs_dir_readdir(struct file *filp, void *dirent, filldir_t filldir) | ||
72 | { | ||
73 | struct v9fs_fcall *fcall = NULL; | ||
74 | struct inode *inode = filp->f_dentry->d_inode; | ||
75 | struct v9fs_session_info *v9ses = v9fs_inode2v9ses(inode); | ||
76 | struct v9fs_fid *file = filp->private_data; | ||
77 | unsigned int i, n; | ||
78 | int fid = -1; | ||
79 | int ret = 0; | ||
80 | struct v9fs_stat *mi = NULL; | ||
81 | int over = 0; | ||
82 | |||
83 | dprintk(DEBUG_VFS, "name %s\n", filp->f_dentry->d_name.name); | ||
84 | |||
85 | fid = file->fid; | ||
86 | |||
87 | mi = kmalloc(v9ses->maxdata, GFP_KERNEL); | ||
88 | if (!mi) | ||
89 | return -ENOMEM; | ||
90 | |||
91 | if (file->rdir_fcall && (filp->f_pos != file->rdir_pos)) { | ||
92 | kfree(file->rdir_fcall); | ||
93 | file->rdir_fcall = NULL; | ||
94 | } | ||
95 | |||
96 | if (file->rdir_fcall) { | ||
97 | n = file->rdir_fcall->params.rread.count; | ||
98 | i = file->rdir_fpos; | ||
99 | while (i < n) { | ||
100 | int s = v9fs_deserialize_stat(v9ses, | ||
101 | file->rdir_fcall->params.rread.data + i, | ||
102 | n - i, mi, v9ses->maxdata); | ||
103 | |||
104 | if (s == 0) { | ||
105 | dprintk(DEBUG_ERROR, | ||
106 | "error while deserializing mistat\n"); | ||
107 | ret = -EIO; | ||
108 | goto FreeStructs; | ||
109 | } | ||
110 | |||
111 | over = filldir(dirent, mi->name, strlen(mi->name), | ||
112 | filp->f_pos, v9fs_qid2ino(&mi->qid), | ||
113 | dt_type(mi)); | ||
114 | |||
115 | if (over) { | ||
116 | file->rdir_fpos = i; | ||
117 | file->rdir_pos = filp->f_pos; | ||
118 | break; | ||
119 | } | ||
120 | |||
121 | i += s; | ||
122 | filp->f_pos += s; | ||
123 | } | ||
124 | |||
125 | if (!over) { | ||
126 | kfree(file->rdir_fcall); | ||
127 | file->rdir_fcall = NULL; | ||
128 | } | ||
129 | } | ||
130 | |||
131 | while (!over) { | ||
132 | ret = v9fs_t_read(v9ses, fid, filp->f_pos, | ||
133 | v9ses->maxdata-V9FS_IOHDRSZ, &fcall); | ||
134 | if (ret < 0) { | ||
135 | dprintk(DEBUG_ERROR, "error while reading: %d: %p\n", | ||
136 | ret, fcall); | ||
137 | goto FreeStructs; | ||
138 | } else if (ret == 0) | ||
139 | break; | ||
140 | |||
141 | n = ret; | ||
142 | i = 0; | ||
143 | while (i < n) { | ||
144 | int s = v9fs_deserialize_stat(v9ses, | ||
145 | fcall->params.rread.data + i, n - i, mi, | ||
146 | v9ses->maxdata); | ||
147 | |||
148 | if (s == 0) { | ||
149 | dprintk(DEBUG_ERROR, | ||
150 | "error while deserializing mistat\n"); | ||
151 | return -EIO; | ||
152 | } | ||
153 | |||
154 | over = filldir(dirent, mi->name, strlen(mi->name), | ||
155 | filp->f_pos, v9fs_qid2ino(&mi->qid), | ||
156 | dt_type(mi)); | ||
157 | |||
158 | if (over) { | ||
159 | file->rdir_fcall = fcall; | ||
160 | file->rdir_fpos = i; | ||
161 | file->rdir_pos = filp->f_pos; | ||
162 | fcall = NULL; | ||
163 | break; | ||
164 | } | ||
165 | |||
166 | i += s; | ||
167 | filp->f_pos += s; | ||
168 | } | ||
169 | |||
170 | kfree(fcall); | ||
171 | } | ||
172 | |||
173 | FreeStructs: | ||
174 | kfree(fcall); | ||
175 | kfree(mi); | ||
176 | return ret; | ||
177 | } | ||
178 | |||
179 | /** | ||
180 | * v9fs_dir_release - close a directory | ||
181 | * @inode: inode of the directory | ||
182 | * @filp: file pointer to a directory | ||
183 | * | ||
184 | */ | ||
185 | |||
186 | int v9fs_dir_release(struct inode *inode, struct file *filp) | ||
187 | { | ||
188 | struct v9fs_session_info *v9ses = v9fs_inode2v9ses(inode); | ||
189 | struct v9fs_fid *fid = filp->private_data; | ||
190 | int fidnum = -1; | ||
191 | |||
192 | dprintk(DEBUG_VFS, "inode: %p filp: %p fid: %d\n", inode, filp, | ||
193 | fid->fid); | ||
194 | fidnum = fid->fid; | ||
195 | |||
196 | filemap_fdatawrite(inode->i_mapping); | ||
197 | filemap_fdatawait(inode->i_mapping); | ||
198 | |||
199 | if (fidnum >= 0) { | ||
200 | fid->fidopen--; | ||
201 | dprintk(DEBUG_VFS, "fidopen: %d v9f->fid: %d\n", fid->fidopen, | ||
202 | fid->fid); | ||
203 | |||
204 | if (fid->fidopen == 0) { | ||
205 | if (v9fs_t_clunk(v9ses, fidnum, NULL)) | ||
206 | dprintk(DEBUG_ERROR, "clunk failed\n"); | ||
207 | |||
208 | v9fs_put_idpool(fid->fid, &v9ses->fidpool); | ||
209 | } | ||
210 | |||
211 | kfree(fid->rdir_fcall); | ||
212 | |||
213 | filp->private_data = NULL; | ||
214 | v9fs_fid_destroy(fid); | ||
215 | } | ||
216 | |||
217 | d_drop(filp->f_dentry); | ||
218 | return 0; | ||
219 | } | ||
220 | |||
221 | struct file_operations v9fs_dir_operations = { | ||
222 | .read = generic_read_dir, | ||
223 | .readdir = v9fs_dir_readdir, | ||
224 | .open = v9fs_file_open, | ||
225 | .release = v9fs_dir_release, | ||
226 | }; | ||
diff --git a/fs/9p/vfs_file.c b/fs/9p/vfs_file.c new file mode 100644 index 000000000000..1f8ae7d580ab --- /dev/null +++ b/fs/9p/vfs_file.c | |||
@@ -0,0 +1,401 @@ | |||
1 | /* | ||
2 | * linux/fs/9p/vfs_file.c | ||
3 | * | ||
4 | * This file contians vfs file ops for 9P2000. | ||
5 | * | ||
6 | * Copyright (C) 2004 by Eric Van Hensbergen <ericvh@gmail.com> | ||
7 | * Copyright (C) 2002 by Ron Minnich <rminnich@lanl.gov> | ||
8 | * | ||
9 | * This program is free software; you can redistribute it and/or modify | ||
10 | * it under the terms of the GNU General Public License as published by | ||
11 | * the Free Software Foundation; either version 2 of the License, or | ||
12 | * (at your option) any later version. | ||
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/file.h> | ||
31 | #include <linux/stat.h> | ||
32 | #include <linux/string.h> | ||
33 | #include <linux/smp_lock.h> | ||
34 | #include <linux/inet.h> | ||
35 | #include <linux/version.h> | ||
36 | #include <linux/list.h> | ||
37 | #include <asm/uaccess.h> | ||
38 | #include <linux/idr.h> | ||
39 | |||
40 | #include "debug.h" | ||
41 | #include "v9fs.h" | ||
42 | #include "9p.h" | ||
43 | #include "v9fs_vfs.h" | ||
44 | #include "fid.h" | ||
45 | |||
46 | /** | ||
47 | * v9fs_file_open - open a file (or directory) | ||
48 | * @inode: inode to be opened | ||
49 | * @file: file being opened | ||
50 | * | ||
51 | */ | ||
52 | |||
53 | int v9fs_file_open(struct inode *inode, struct file *file) | ||
54 | { | ||
55 | struct v9fs_session_info *v9ses = v9fs_inode2v9ses(inode); | ||
56 | struct v9fs_fid *v9fid = v9fs_fid_lookup(file->f_dentry, FID_WALK); | ||
57 | struct v9fs_fid *v9newfid = NULL; | ||
58 | struct v9fs_fcall *fcall = NULL; | ||
59 | int open_mode = 0; | ||
60 | unsigned int iounit = 0; | ||
61 | int newfid = -1; | ||
62 | long result = -1; | ||
63 | |||
64 | dprintk(DEBUG_VFS, "inode: %p file: %p v9fid= %p\n", inode, file, | ||
65 | v9fid); | ||
66 | |||
67 | if (!v9fid) { | ||
68 | struct dentry *dentry = file->f_dentry; | ||
69 | dprintk(DEBUG_ERROR, "Couldn't resolve fid from dentry\n"); | ||
70 | |||
71 | /* XXX - some duplication from lookup, generalize later */ | ||
72 | /* basically vfs_lookup is too heavy weight */ | ||
73 | v9fid = v9fs_fid_lookup(file->f_dentry, FID_OP); | ||
74 | if (!v9fid) | ||
75 | return -EBADF; | ||
76 | |||
77 | v9fid = v9fs_fid_lookup(dentry->d_parent, FID_WALK); | ||
78 | if (!v9fid) | ||
79 | return -EBADF; | ||
80 | |||
81 | newfid = v9fs_get_idpool(&v9ses->fidpool); | ||
82 | if (newfid < 0) { | ||
83 | eprintk(KERN_WARNING, "newfid fails!\n"); | ||
84 | return -ENOSPC; | ||
85 | } | ||
86 | |||
87 | result = | ||
88 | v9fs_t_walk(v9ses, v9fid->fid, newfid, | ||
89 | (char *)file->f_dentry->d_name.name, NULL); | ||
90 | if (result < 0) { | ||
91 | v9fs_put_idpool(newfid, &v9ses->fidpool); | ||
92 | dprintk(DEBUG_ERROR, "rewalk didn't work\n"); | ||
93 | return -EBADF; | ||
94 | } | ||
95 | |||
96 | v9fid = v9fs_fid_create(dentry); | ||
97 | if (v9fid == NULL) { | ||
98 | dprintk(DEBUG_ERROR, "couldn't insert\n"); | ||
99 | return -ENOMEM; | ||
100 | } | ||
101 | v9fid->fid = newfid; | ||
102 | } | ||
103 | |||
104 | if (v9fid->fidcreate) { | ||
105 | /* create case */ | ||
106 | newfid = v9fid->fid; | ||
107 | iounit = v9fid->iounit; | ||
108 | v9fid->fidcreate = 0; | ||
109 | } else { | ||
110 | if (!S_ISDIR(inode->i_mode)) | ||
111 | newfid = v9fid->fid; | ||
112 | else { | ||
113 | newfid = v9fs_get_idpool(&v9ses->fidpool); | ||
114 | if (newfid < 0) { | ||
115 | eprintk(KERN_WARNING, "allocation failed\n"); | ||
116 | return -ENOSPC; | ||
117 | } | ||
118 | /* This would be a somewhat critical clone */ | ||
119 | result = | ||
120 | v9fs_t_walk(v9ses, v9fid->fid, newfid, NULL, | ||
121 | &fcall); | ||
122 | if (result < 0) { | ||
123 | dprintk(DEBUG_ERROR, "clone error: %s\n", | ||
124 | FCALL_ERROR(fcall)); | ||
125 | kfree(fcall); | ||
126 | return result; | ||
127 | } | ||
128 | |||
129 | v9newfid = v9fs_fid_create(file->f_dentry); | ||
130 | v9newfid->fid = newfid; | ||
131 | v9newfid->qid = v9fid->qid; | ||
132 | v9newfid->iounit = v9fid->iounit; | ||
133 | v9newfid->fidopen = 0; | ||
134 | v9newfid->fidclunked = 0; | ||
135 | v9newfid->v9ses = v9ses; | ||
136 | v9fid = v9newfid; | ||
137 | kfree(fcall); | ||
138 | } | ||
139 | |||
140 | /* TODO: do special things for O_EXCL, O_NOFOLLOW, O_SYNC */ | ||
141 | /* translate open mode appropriately */ | ||
142 | open_mode = file->f_flags & 0x3; | ||
143 | |||
144 | if (file->f_flags & O_EXCL) | ||
145 | open_mode |= V9FS_OEXCL; | ||
146 | |||
147 | if (v9ses->extended) { | ||
148 | if (file->f_flags & O_TRUNC) | ||
149 | open_mode |= V9FS_OTRUNC; | ||
150 | |||
151 | if (file->f_flags & O_APPEND) | ||
152 | open_mode |= V9FS_OAPPEND; | ||
153 | } | ||
154 | |||
155 | result = v9fs_t_open(v9ses, newfid, open_mode, &fcall); | ||
156 | if (result < 0) { | ||
157 | dprintk(DEBUG_ERROR, | ||
158 | "open failed, open_mode 0x%x: %s\n", open_mode, | ||
159 | FCALL_ERROR(fcall)); | ||
160 | kfree(fcall); | ||
161 | return result; | ||
162 | } | ||
163 | |||
164 | iounit = fcall->params.ropen.iounit; | ||
165 | kfree(fcall); | ||
166 | } | ||
167 | |||
168 | |||
169 | file->private_data = v9fid; | ||
170 | |||
171 | v9fid->rdir_pos = 0; | ||
172 | v9fid->rdir_fcall = NULL; | ||
173 | v9fid->fidopen = 1; | ||
174 | v9fid->filp = file; | ||
175 | v9fid->iounit = iounit; | ||
176 | |||
177 | return 0; | ||
178 | } | ||
179 | |||
180 | /** | ||
181 | * v9fs_file_lock - lock a file (or directory) | ||
182 | * @inode: inode to be opened | ||
183 | * @file: file being opened | ||
184 | * | ||
185 | * XXX - this looks like a local only lock, we should extend into 9P | ||
186 | * by using open exclusive | ||
187 | */ | ||
188 | |||
189 | static int v9fs_file_lock(struct file *filp, int cmd, struct file_lock *fl) | ||
190 | { | ||
191 | int res = 0; | ||
192 | struct inode *inode = filp->f_dentry->d_inode; | ||
193 | |||
194 | dprintk(DEBUG_VFS, "filp: %p lock: %p\n", filp, fl); | ||
195 | |||
196 | /* No mandatory locks */ | ||
197 | if ((inode->i_mode & (S_ISGID | S_IXGRP)) == S_ISGID) | ||
198 | return -ENOLCK; | ||
199 | |||
200 | if ((IS_SETLK(cmd) || IS_SETLKW(cmd)) && fl->fl_type != F_UNLCK) { | ||
201 | filemap_fdatawrite(inode->i_mapping); | ||
202 | filemap_fdatawait(inode->i_mapping); | ||
203 | invalidate_inode_pages(&inode->i_data); | ||
204 | } | ||
205 | |||
206 | return res; | ||
207 | } | ||
208 | |||
209 | /** | ||
210 | * v9fs_read - read from a file (internal) | ||
211 | * @filep: file pointer to read | ||
212 | * @data: data buffer to read data into | ||
213 | * @count: size of buffer | ||
214 | * @offset: offset at which to read data | ||
215 | * | ||
216 | */ | ||
217 | |||
218 | static ssize_t | ||
219 | v9fs_read(struct file *filp, char *buffer, size_t count, loff_t * offset) | ||
220 | { | ||
221 | struct inode *inode = filp->f_dentry->d_inode; | ||
222 | struct v9fs_session_info *v9ses = v9fs_inode2v9ses(inode); | ||
223 | struct v9fs_fid *v9f = filp->private_data; | ||
224 | struct v9fs_fcall *fcall = NULL; | ||
225 | int fid = v9f->fid; | ||
226 | int rsize = 0; | ||
227 | int result = 0; | ||
228 | int total = 0; | ||
229 | |||
230 | dprintk(DEBUG_VFS, "\n"); | ||
231 | |||
232 | rsize = v9ses->maxdata - V9FS_IOHDRSZ; | ||
233 | if (v9f->iounit != 0 && rsize > v9f->iounit) | ||
234 | rsize = v9f->iounit; | ||
235 | |||
236 | do { | ||
237 | if (count < rsize) | ||
238 | rsize = count; | ||
239 | |||
240 | result = v9fs_t_read(v9ses, fid, *offset, rsize, &fcall); | ||
241 | |||
242 | if (result < 0) { | ||
243 | printk(KERN_ERR "9P2000: v9fs_t_read returned %d\n", | ||
244 | result); | ||
245 | |||
246 | kfree(fcall); | ||
247 | return total; | ||
248 | } else | ||
249 | *offset += result; | ||
250 | |||
251 | /* XXX - extra copy */ | ||
252 | memcpy(buffer, fcall->params.rread.data, result); | ||
253 | count -= result; | ||
254 | buffer += result; | ||
255 | total += result; | ||
256 | |||
257 | kfree(fcall); | ||
258 | |||
259 | if (result < rsize) | ||
260 | break; | ||
261 | } while (count); | ||
262 | |||
263 | return total; | ||
264 | } | ||
265 | |||
266 | /** | ||
267 | * v9fs_file_read - read from a file | ||
268 | * @filep: file pointer to read | ||
269 | * @data: data buffer to read data into | ||
270 | * @count: size of buffer | ||
271 | * @offset: offset at which to read data | ||
272 | * | ||
273 | */ | ||
274 | |||
275 | static ssize_t | ||
276 | v9fs_file_read(struct file *filp, char __user * data, size_t count, | ||
277 | loff_t * offset) | ||
278 | { | ||
279 | int retval = -1; | ||
280 | int ret = 0; | ||
281 | char *buffer; | ||
282 | |||
283 | buffer = kmalloc(count, GFP_KERNEL); | ||
284 | if (!buffer) | ||
285 | return -ENOMEM; | ||
286 | |||
287 | retval = v9fs_read(filp, buffer, count, offset); | ||
288 | if (retval > 0) { | ||
289 | if ((ret = copy_to_user(data, buffer, retval)) != 0) { | ||
290 | dprintk(DEBUG_ERROR, "Problem copying to user %d\n", | ||
291 | ret); | ||
292 | retval = ret; | ||
293 | } | ||
294 | } | ||
295 | |||
296 | kfree(buffer); | ||
297 | |||
298 | return retval; | ||
299 | } | ||
300 | |||
301 | /** | ||
302 | * v9fs_write - write to a file | ||
303 | * @filep: file pointer to write | ||
304 | * @data: data buffer to write data from | ||
305 | * @count: size of buffer | ||
306 | * @offset: offset at which to write data | ||
307 | * | ||
308 | */ | ||
309 | |||
310 | static ssize_t | ||
311 | v9fs_write(struct file *filp, char *buffer, size_t count, loff_t * offset) | ||
312 | { | ||
313 | struct inode *inode = filp->f_dentry->d_inode; | ||
314 | struct v9fs_session_info *v9ses = v9fs_inode2v9ses(inode); | ||
315 | struct v9fs_fid *v9fid = filp->private_data; | ||
316 | struct v9fs_fcall *fcall; | ||
317 | int fid = v9fid->fid; | ||
318 | int result = -EIO; | ||
319 | int rsize = 0; | ||
320 | int total = 0; | ||
321 | |||
322 | dprintk(DEBUG_VFS, "data %p count %d offset %x\n", buffer, (int)count, | ||
323 | (int)*offset); | ||
324 | rsize = v9ses->maxdata - V9FS_IOHDRSZ; | ||
325 | if (v9fid->iounit != 0 && rsize > v9fid->iounit) | ||
326 | rsize = v9fid->iounit; | ||
327 | |||
328 | dump_data(buffer, count); | ||
329 | |||
330 | do { | ||
331 | if (count < rsize) | ||
332 | rsize = count; | ||
333 | |||
334 | result = | ||
335 | v9fs_t_write(v9ses, fid, *offset, rsize, buffer, &fcall); | ||
336 | if (result < 0) { | ||
337 | eprintk(KERN_ERR, "error while writing: %s(%d)\n", | ||
338 | FCALL_ERROR(fcall), result); | ||
339 | kfree(fcall); | ||
340 | return result; | ||
341 | } else | ||
342 | *offset += result; | ||
343 | |||
344 | kfree(fcall); | ||
345 | |||
346 | if (result != rsize) { | ||
347 | eprintk(KERN_ERR, | ||
348 | "short write: v9fs_t_write returned %d\n", | ||
349 | result); | ||
350 | break; | ||
351 | } | ||
352 | |||
353 | count -= result; | ||
354 | buffer += result; | ||
355 | total += result; | ||
356 | } while (count); | ||
357 | |||
358 | return total; | ||
359 | } | ||
360 | |||
361 | /** | ||
362 | * v9fs_file_write - write to a file | ||
363 | * @filep: file pointer to write | ||
364 | * @data: data buffer to write data from | ||
365 | * @count: size of buffer | ||
366 | * @offset: offset at which to write data | ||
367 | * | ||
368 | */ | ||
369 | |||
370 | static ssize_t | ||
371 | v9fs_file_write(struct file *filp, const char __user * data, | ||
372 | size_t count, loff_t * offset) | ||
373 | { | ||
374 | int ret = -1; | ||
375 | char *buffer; | ||
376 | |||
377 | buffer = kmalloc(count, GFP_KERNEL); | ||
378 | if (buffer == NULL) | ||
379 | return -ENOMEM; | ||
380 | |||
381 | ret = copy_from_user(buffer, data, count); | ||
382 | if (ret) { | ||
383 | dprintk(DEBUG_ERROR, "Problem copying from user\n"); | ||
384 | ret = -EFAULT; | ||
385 | } else { | ||
386 | ret = v9fs_write(filp, buffer, count, offset); | ||
387 | } | ||
388 | |||
389 | kfree(buffer); | ||
390 | |||
391 | return ret; | ||
392 | } | ||
393 | |||
394 | struct file_operations v9fs_file_operations = { | ||
395 | .llseek = generic_file_llseek, | ||
396 | .read = v9fs_file_read, | ||
397 | .write = v9fs_file_write, | ||
398 | .open = v9fs_file_open, | ||
399 | .release = v9fs_dir_release, | ||
400 | .lock = v9fs_file_lock, | ||
401 | }; | ||