Whamcloud - gitweb
- obd filter works over ext2, but bonnie++ is buggie
[fs/lustre-release.git] / lustre / obdfs / namei.c
1 /*
2  *  linux/fs/obdfs/namei.c
3  *
4  * This code is issued under the GNU General Public License.
5  * See the file COPYING in this distribution
6  *
7  * Copyright (C) 1992, 1993, 1994, 1995
8  * Remy Card (card@masi.ibp.fr)
9  * Laboratoire MASI - Institut Blaise Pascal
10  * Universite Pierre et Marie Curie (Paris VI)
11  *
12  *  from
13  *
14  *  linux/fs/ext2/namei.c
15  *
16  *  Copyright (C) 1991, 1992  Linus Torvalds
17  *
18  *  Big-endian to little-endian byte-swapping/bitmaps by
19  *        David S. Miller (davem@caip.rutgers.edu), 1995
20  *  Directory entry file type support and forward compatibility hooks
21  *      for B-tree directories by Theodore Ts'o (tytso@mit.edu), 1998
22  * 
23  *  Changes for use in OBDFS
24  *  Copyright (c) 1999, Seagate Technology Inc.
25  *  Copyright (C) 2001, Cluster File Systems, Inc.
26  *                       Rewritten based on recent ext2 page cache use.
27  * 
28  */
29
30 #include <linux/fs.h>
31 #include <linux/locks.h>
32 #include <linux/quotaops.h>
33 #include <linux/obd_support.h>
34 #include <linux/obdfs.h>
35 extern struct address_space_operations obdfs_aops;
36
37 /* from super.c */
38 extern void obdfs_change_inode(struct inode *inode);
39 extern int obdfs_setattr(struct dentry *de, struct iattr *attr);
40
41 /* from dir.c */
42 extern int ext2_add_link (struct dentry *dentry, struct inode *inode);
43 extern ino_t ext2_inode_by_name(struct inode * dir, struct dentry *dentry);
44 int ext2_make_empty(struct inode *inode, struct inode *parent);
45 struct ext2_dir_entry_2 * ext2_find_entry (struct inode * dir,
46                    struct dentry *dentry, struct page ** res_page);
47 int ext2_delete_entry (struct ext2_dir_entry_2 * dir, struct page * page );
48 int ext2_empty_dir (struct inode * inode);
49 struct ext2_dir_entry_2 * ext2_dotdot (struct inode *dir, struct page **p);
50 void ext2_set_link(struct inode *dir, struct ext2_dir_entry_2 *de,
51                    struct page *page, struct inode *inode);
52
53 /*
54  * Couple of helper functions - make the code slightly cleaner.
55  */
56 static inline void ext2_inc_count(struct inode *inode)
57 {
58         inode->i_nlink++;
59         obdfs_change_inode(inode);
60 }
61
62 /* postpone the disk update until the inode really goes away */ 
63 static inline void ext2_dec_count(struct inode *inode)
64 {
65         inode->i_nlink--;
66         if (inode->i_nlink > 0) 
67                 obdfs_change_inode(inode);
68 }
69
70 static inline int ext2_add_nondir(struct dentry *dentry, struct inode *inode)
71 {
72         int err;
73         err = ext2_add_link(dentry, inode);
74         if (!err) {
75                 d_instantiate(dentry, inode);
76                 return 0;
77         }
78         ext2_dec_count(inode);
79         iput(inode);
80         return err;
81 }
82
83 /* methods */
84 static struct dentry *obdfs_lookup(struct inode * dir, struct dentry *dentry)
85 {
86         struct obdo *oa;
87         struct inode * inode = NULL;
88         ino_t ino;
89         
90         ENTRY;
91         if (dentry->d_name.len > EXT2_NAME_LEN)
92                 return ERR_PTR(-ENAMETOOLONG);
93
94         ino = ext2_inode_by_name(dir, dentry);
95         if (!ino)
96                 goto negative;
97
98         oa = obdo_fromid(IID(dir), ino, OBD_MD_FLNOTOBD | OBD_MD_FLBLOCKS);
99         if ( IS_ERR(oa) ) {
100                 printk(__FUNCTION__ ": obdo_fromid failed\n");
101                 EXIT;
102                 return ERR_PTR(-EACCES); 
103         }
104
105         inode = iget4(dir->i_sb, ino, NULL, oa);
106         obdo_free(oa);
107
108         if (!inode) 
109                 return ERR_PTR(-EACCES);
110
111  negative:
112         d_add(dentry, inode);
113         return NULL;
114 }
115
116
117 /*
118  * NOTE! unlike strncmp, ext2_match returns 1 for success, 0 for failure.
119  *
120  * `len <= EXT2_NAME_LEN' is guaranteed by caller.
121  * `de != NULL' is guaranteed by caller.
122  */
123 static inline int ext2_match (int len, const char * const name,
124                        struct ext2_dir_entry_2 * de)
125 {
126         if (len != de->name_len)
127                 return 0;
128         if (!de->inode)
129                 return 0;
130         return !memcmp(name, de->name, len);
131 }
132
133 static struct inode *obdfs_new_inode(struct inode *dir, int mode)
134 {
135         struct obdo *oa;
136         struct inode *inode;
137         int err;
138
139         ENTRY;
140         if (IOPS(dir, create) == NULL) {
141                 printk(KERN_ERR __FUNCTION__ ": no create method!\n");
142                 EXIT;
143                 return ERR_PTR(-EIO);
144         }
145         oa = obdo_alloc();
146         if (!oa) {
147                 EXIT;
148                 return ERR_PTR(-ENOMEM);
149         }
150
151         /* Send a hint to the create method on the type of file to create */
152         oa->o_mode = mode;
153         oa->o_valid |= OBD_MD_FLMODE;
154         CDEBUG(D_INODE, "\n");
155         err = IOPS(dir, create)(IID(dir), oa);
156         CDEBUG(D_INODE, "\n");
157
158         if ( err ) {
159                 printk("new_inode - fatal: err %d\n", err);
160                 obdo_free(oa);
161                 EXIT;
162                 return ERR_PTR(err);
163         }
164         CDEBUG(D_INODE, "\n");
165
166         inode = iget4(dir->i_sb, (ino_t)oa->o_id, NULL, oa);
167         CDEBUG(D_INODE, "\n");
168         obdo_free(oa);
169
170         if (!inode) {
171                 printk("new_inode -fatal:  %ld\n", (long)oa->o_id);
172                 IOPS(dir, destroy)(IID(dir), oa);
173                 EXIT;
174                 return ERR_PTR(-EIO);
175         }
176
177         if (!list_empty(&inode->i_dentry)) {
178                 printk("new_inode -fatal: aliases %ld, ct %d lnk %d\n", 
179                        (long)oa->o_id,
180                        atomic_read(&inode->i_count), 
181                        inode->i_nlink);
182                 IOPS(dir, destroy)(IID(dir), oa);
183                 iput(inode);
184                 EXIT;
185                 return ERR_PTR(-EIO);
186         }
187
188         EXIT;
189         return inode;
190 } /* obdfs_new_inode */
191
192
193 /*
194  * By the time this is called, we already have created
195  * the directory cache entry for the new file, but it
196  * is so far negative - it has no inode.
197  *
198  * If the create succeeds, we fill in the inode information
199  * with d_instantiate(). 
200  */
201 static int obdfs_create (struct inode * dir, struct dentry * dentry, int mode)
202 {
203         struct inode * inode = obdfs_new_inode (dir, mode);
204         int err = PTR_ERR(inode);
205         if (!IS_ERR(inode)) {
206                 inode->i_op = &obdfs_file_inode_operations;
207                 inode->i_fop = &obdfs_file_operations;
208                 inode->i_mapping->a_ops = &obdfs_aops;
209                 err = ext2_add_nondir(dentry, inode);
210         }
211         return err;
212 } /* obdfs_create */
213
214
215 static int obdfs_mknod (struct inode * dir, struct dentry *dentry, int mode, int rdev)
216 {
217         struct inode * inode = obdfs_new_inode (dir, mode);
218         int err = PTR_ERR(inode);
219         if (!IS_ERR(inode)) {
220                 init_special_inode(inode, mode, rdev);
221                 obdfs_change_inode(inode);
222                 err = ext2_add_nondir(dentry, inode);
223         }
224         return err;
225 }
226
227 static int obdfs_symlink (struct inode * dir, struct dentry * dentry,
228         const char * symname)
229 {
230         struct super_block * sb = dir->i_sb;
231         int err = -ENAMETOOLONG;
232         unsigned l = strlen(symname)+1;
233         struct inode * inode;
234         struct obdfs_inode_info *oinfo;
235
236         if (l > sb->s_blocksize)
237                 goto out;
238
239         inode = obdfs_new_inode (dir, S_IFLNK | S_IRWXUGO);
240         err = PTR_ERR(inode);
241         if (IS_ERR(inode))
242                 goto out;
243
244         oinfo = obdfs_i2info(inode);
245         if (l >= sizeof(oinfo->oi_inline)) {
246                 /* slow symlink */
247                 inode->i_op = &page_symlink_inode_operations;
248                 inode->i_mapping->a_ops = &obdfs_aops;
249                 err = block_symlink(inode, symname, l);
250                 if (err)
251                         goto out_fail;
252         } else {
253                 /* fast symlink */
254                 inode->i_op = &obdfs_fast_symlink_inode_operations;
255                 memcpy(oinfo->oi_inline, symname, l);
256                 inode->i_size = l-1;
257         }
258         obdfs_change_inode(inode);
259
260         err = ext2_add_nondir(dentry, inode);
261 out:
262         return err;
263
264 out_fail:
265         ext2_dec_count(inode);
266         iput (inode);
267         goto out;
268 }
269
270
271
272 static int obdfs_link (struct dentry * old_dentry, struct inode * dir,
273         struct dentry *dentry)
274 {
275         struct inode *inode = old_dentry->d_inode;
276
277         if (S_ISDIR(inode->i_mode))
278                 return -EPERM;
279
280         if (inode->i_nlink >= EXT2_LINK_MAX)
281                 return -EMLINK;
282
283         inode->i_ctime = CURRENT_TIME;
284         ext2_inc_count(inode);
285         atomic_inc(&inode->i_count);
286
287         return ext2_add_nondir(dentry, inode);
288 }
289
290
291 static int obdfs_mkdir(struct inode * dir, struct dentry * dentry, int mode)
292 {
293         struct inode * inode;
294         int err = -EMLINK;
295         ENTRY;
296
297         if (dir->i_nlink >= EXT2_LINK_MAX)
298                 goto out;
299
300         ext2_inc_count(dir);
301
302         inode = obdfs_new_inode (dir, S_IFDIR | mode);
303         err = PTR_ERR(inode);
304         if (IS_ERR(inode))
305                 goto out_dir;
306
307         inode->i_op = &obdfs_dir_inode_operations;
308         inode->i_fop = &obdfs_dir_operations;
309         inode->i_mapping->a_ops = &obdfs_aops;
310
311         ext2_inc_count(inode);
312
313         err = ext2_make_empty(inode, dir);
314         if (err)
315                 goto out_fail;
316
317         err = ext2_add_link(dentry, inode);
318         if (err)
319                 goto out_fail;
320
321         d_instantiate(dentry, inode);
322 out:
323         EXIT;
324         return err;
325
326 out_fail:
327         ext2_dec_count(inode);
328         ext2_dec_count(inode);
329         iput(inode);
330         EXIT;
331 out_dir:
332         ext2_dec_count(dir);
333         EXIT;
334         goto out;
335 }
336
337 static int obdfs_unlink(struct inode * dir, struct dentry *dentry)
338 {
339         struct inode * inode = dentry->d_inode;
340         struct ext2_dir_entry_2 * de;
341         struct page * page;
342         int err = -ENOENT;
343
344         de = ext2_find_entry (dir, dentry, &page);
345         if (!de)
346                 goto out;
347
348         err = ext2_delete_entry (de, page);
349         if (err)
350                 goto out;
351
352         inode->i_ctime = dir->i_ctime;
353         ext2_dec_count(inode);
354         err = 0;
355 out:
356         return err;
357 }
358
359
360 static int obdfs_rmdir (struct inode * dir, struct dentry *dentry)
361 {
362         struct inode * inode = dentry->d_inode;
363         int err = -ENOTEMPTY;
364
365         if (ext2_empty_dir(inode)) {
366                 err = obdfs_unlink(dir, dentry);
367                 if (!err) {
368                         inode->i_size = 0;
369                         ext2_dec_count(inode);
370                         ext2_dec_count(dir);
371                 }
372         }
373         return err;
374 }
375
376 static int obdfs_rename (struct inode * old_dir, struct dentry * old_dentry,
377         struct inode * new_dir, struct dentry * new_dentry )
378 {
379         struct inode * old_inode = old_dentry->d_inode;
380         struct inode * new_inode = new_dentry->d_inode;
381         struct page * dir_page = NULL;
382         struct ext2_dir_entry_2 * dir_de = NULL;
383         struct page * old_page;
384         struct ext2_dir_entry_2 * old_de;
385         int err = -ENOENT;
386
387         old_de = ext2_find_entry (old_dir, old_dentry, &old_page);
388         if (!old_de)
389                 goto out;
390
391         if (S_ISDIR(old_inode->i_mode)) {
392                 err = -EIO;
393                 dir_de = ext2_dotdot(old_inode, &dir_page);
394                 if (!dir_de)
395                         goto out_old;
396         }
397
398         if (new_inode) {
399                 struct page *new_page;
400                 struct ext2_dir_entry_2 *new_de;
401
402                 err = -ENOTEMPTY;
403                 if (dir_de && !ext2_empty_dir (new_inode))
404                         goto out_dir;
405
406                 err = -ENOENT;
407                 new_de = ext2_find_entry (new_dir, new_dentry, &new_page);
408                 if (!new_de)
409                         goto out_dir;
410                 ext2_inc_count(old_inode);
411                 ext2_set_link(new_dir, new_de, new_page, old_inode);
412                 new_inode->i_ctime = CURRENT_TIME;
413                 if (dir_de)
414                         new_inode->i_nlink--;
415                 ext2_dec_count(new_inode);
416         } else {
417                 if (dir_de) {
418                         err = -EMLINK;
419                         if (new_dir->i_nlink >= EXT2_LINK_MAX)
420                                 goto out_dir;
421                 }
422                 ext2_inc_count(old_inode);
423                 err = ext2_add_link(new_dentry, old_inode);
424                 if (err) {
425                         ext2_dec_count(old_inode);
426                         goto out_dir;
427                 }
428                 if (dir_de)
429                         ext2_inc_count(new_dir);
430         }
431
432         ext2_delete_entry (old_de, old_page);
433         ext2_dec_count(old_inode);
434
435         if (dir_de) {
436                 ext2_set_link(old_inode, dir_de, dir_page, new_dir);
437                 ext2_dec_count(old_dir);
438         }
439         return 0;
440
441
442 out_dir:
443         if (dir_de) {
444                 kunmap(dir_page);
445                 page_cache_release(dir_page);
446         }
447 out_old:
448         kunmap(old_page);
449         page_cache_release(old_page);
450 out:
451         return err;
452 }
453
454 struct inode_operations obdfs_dir_inode_operations = {
455         create:         obdfs_create,
456         lookup:         obdfs_lookup,
457         link:           obdfs_link,
458         unlink:         obdfs_unlink,
459         symlink:        obdfs_symlink,
460         mkdir:          obdfs_mkdir,
461         rmdir:          obdfs_rmdir,
462         mknod:          obdfs_mknod,
463         rename:         obdfs_rename,
464         setattr:        obdfs_setattr
465 };