omfs: stop playing silly buggers with omfs_unlink() in ->rename()
[linux-2.6.git] / fs / omfs / dir.c
1 /*
2  * OMFS (as used by RIO Karma) directory operations.
3  * Copyright (C) 2005 Bob Copeland <me@bobcopeland.com>
4  * Released under GPL v2.
5  */
6
7 #include <linux/fs.h>
8 #include <linux/ctype.h>
9 #include <linux/buffer_head.h>
10 #include "omfs.h"
11
12 static int omfs_hash(const char *name, int namelen, int mod)
13 {
14         int i, hash = 0;
15         for (i = 0; i < namelen; i++)
16                 hash ^= tolower(name[i]) << (i % 24);
17         return hash % mod;
18 }
19
20 /*
21  * Finds the bucket for a given name and reads the containing block;
22  * *ofs is set to the offset of the first list entry.
23  */
24 static struct buffer_head *omfs_get_bucket(struct inode *dir,
25                 const char *name, int namelen, int *ofs)
26 {
27         int nbuckets = (dir->i_size - OMFS_DIR_START)/8;
28         int bucket = omfs_hash(name, namelen, nbuckets);
29
30         *ofs = OMFS_DIR_START + bucket * 8;
31         return omfs_bread(dir->i_sb, dir->i_ino);
32 }
33
34 static struct buffer_head *omfs_scan_list(struct inode *dir, u64 block,
35                                 const char *name, int namelen,
36                                 u64 *prev_block)
37 {
38         struct buffer_head *bh;
39         struct omfs_inode *oi;
40         int err = -ENOENT;
41         *prev_block = ~0;
42
43         while (block != ~0) {
44                 bh = omfs_bread(dir->i_sb, block);
45                 if (!bh) {
46                         err = -EIO;
47                         goto err;
48                 }
49
50                 oi = (struct omfs_inode *) bh->b_data;
51                 if (omfs_is_bad(OMFS_SB(dir->i_sb), &oi->i_head, block)) {
52                         brelse(bh);
53                         goto err;
54                 }
55
56                 if (strncmp(oi->i_name, name, namelen) == 0)
57                         return bh;
58
59                 *prev_block = block;
60                 block = be64_to_cpu(oi->i_sibling);
61                 brelse(bh);
62         }
63 err:
64         return ERR_PTR(err);
65 }
66
67 static struct buffer_head *omfs_find_entry(struct inode *dir,
68                                            const char *name, int namelen)
69 {
70         struct buffer_head *bh;
71         int ofs;
72         u64 block, dummy;
73
74         bh = omfs_get_bucket(dir, name, namelen, &ofs);
75         if (!bh)
76                 return ERR_PTR(-EIO);
77
78         block = be64_to_cpu(*((__be64 *) &bh->b_data[ofs]));
79         brelse(bh);
80
81         return omfs_scan_list(dir, block, name, namelen, &dummy);
82 }
83
84 int omfs_make_empty(struct inode *inode, struct super_block *sb)
85 {
86         struct omfs_sb_info *sbi = OMFS_SB(sb);
87         struct buffer_head *bh;
88         struct omfs_inode *oi;
89
90         bh = omfs_bread(sb, inode->i_ino);
91         if (!bh)
92                 return -ENOMEM;
93
94         memset(bh->b_data, 0, sizeof(struct omfs_inode));
95
96         if (inode->i_mode & S_IFDIR) {
97                 memset(&bh->b_data[OMFS_DIR_START], 0xff,
98                         sbi->s_sys_blocksize - OMFS_DIR_START);
99         } else
100                 omfs_make_empty_table(bh, OMFS_EXTENT_START);
101
102         oi = (struct omfs_inode *) bh->b_data;
103         oi->i_head.h_self = cpu_to_be64(inode->i_ino);
104         oi->i_sibling = ~cpu_to_be64(0ULL);
105
106         mark_buffer_dirty(bh);
107         brelse(bh);
108         return 0;
109 }
110
111 static int omfs_add_link(struct dentry *dentry, struct inode *inode)
112 {
113         struct inode *dir = dentry->d_parent->d_inode;
114         const char *name = dentry->d_name.name;
115         int namelen = dentry->d_name.len;
116         struct omfs_inode *oi;
117         struct buffer_head *bh;
118         u64 block;
119         __be64 *entry;
120         int ofs;
121
122         /* just prepend to head of queue in proper bucket */
123         bh = omfs_get_bucket(dir, name, namelen, &ofs);
124         if (!bh)
125                 goto out;
126
127         entry = (__be64 *) &bh->b_data[ofs];
128         block = be64_to_cpu(*entry);
129         *entry = cpu_to_be64(inode->i_ino);
130         mark_buffer_dirty(bh);
131         brelse(bh);
132
133         /* now set the sibling and parent pointers on the new inode */
134         bh = omfs_bread(dir->i_sb, inode->i_ino);
135         if (!bh)
136                 goto out;
137
138         oi = (struct omfs_inode *) bh->b_data;
139         memcpy(oi->i_name, name, namelen);
140         memset(oi->i_name + namelen, 0, OMFS_NAMELEN - namelen);
141         oi->i_sibling = cpu_to_be64(block);
142         oi->i_parent = cpu_to_be64(dir->i_ino);
143         mark_buffer_dirty(bh);
144         brelse(bh);
145
146         dir->i_ctime = CURRENT_TIME_SEC;
147
148         /* mark affected inodes dirty to rebuild checksums */
149         mark_inode_dirty(dir);
150         mark_inode_dirty(inode);
151         return 0;
152 out:
153         return -ENOMEM;
154 }
155
156 static int omfs_delete_entry(struct dentry *dentry)
157 {
158         struct inode *dir = dentry->d_parent->d_inode;
159         struct inode *dirty;
160         const char *name = dentry->d_name.name;
161         int namelen = dentry->d_name.len;
162         struct omfs_inode *oi;
163         struct buffer_head *bh, *bh2;
164         __be64 *entry, next;
165         u64 block, prev;
166         int ofs;
167         int err = -ENOMEM;
168
169         /* delete the proper node in the bucket's linked list */
170         bh = omfs_get_bucket(dir, name, namelen, &ofs);
171         if (!bh)
172                 goto out;
173
174         entry = (__be64 *) &bh->b_data[ofs];
175         block = be64_to_cpu(*entry);
176
177         bh2 = omfs_scan_list(dir, block, name, namelen, &prev);
178         if (IS_ERR(bh2)) {
179                 err = PTR_ERR(bh2);
180                 goto out_free_bh;
181         }
182
183         oi = (struct omfs_inode *) bh2->b_data;
184         next = oi->i_sibling;
185         brelse(bh2);
186
187         if (prev != ~0) {
188                 /* found in middle of list, get list ptr */
189                 brelse(bh);
190                 bh = omfs_bread(dir->i_sb, prev);
191                 if (!bh)
192                         goto out;
193
194                 oi = (struct omfs_inode *) bh->b_data;
195                 entry = &oi->i_sibling;
196         }
197
198         *entry = next;
199         mark_buffer_dirty(bh);
200
201         if (prev != ~0) {
202                 dirty = omfs_iget(dir->i_sb, prev);
203                 if (!IS_ERR(dirty)) {
204                         mark_inode_dirty(dirty);
205                         iput(dirty);
206                 }
207         }
208
209         err = 0;
210 out_free_bh:
211         brelse(bh);
212 out:
213         return err;
214 }
215
216 static int omfs_dir_is_empty(struct inode *inode)
217 {
218         int nbuckets = (inode->i_size - OMFS_DIR_START) / 8;
219         struct buffer_head *bh;
220         u64 *ptr;
221         int i;
222
223         bh = omfs_bread(inode->i_sb, inode->i_ino);
224
225         if (!bh)
226                 return 0;
227
228         ptr = (u64 *) &bh->b_data[OMFS_DIR_START];
229
230         for (i = 0; i < nbuckets; i++, ptr++)
231                 if (*ptr != ~0)
232                         break;
233
234         brelse(bh);
235         return *ptr != ~0;
236 }
237
238 static int omfs_unlink(struct inode *dir, struct dentry *dentry)
239 {
240         int ret;
241         struct inode *inode = dentry->d_inode;
242
243         ret = omfs_delete_entry(dentry);
244         if (ret)
245                 goto end_unlink;
246
247         inode_dec_link_count(inode);
248         mark_inode_dirty(dir);
249
250 end_unlink:
251         return ret;
252 }
253
254 static int omfs_rmdir(struct inode *dir, struct dentry *dentry)
255 {
256         int err = -ENOTEMPTY;
257         struct inode *inode = dentry->d_inode;
258
259         if (omfs_dir_is_empty(inode)) {
260                 err = omfs_unlink(dir, dentry);
261                 if (!err)
262                         inode_dec_link_count(inode);
263         }
264         return err;
265 }
266
267 static int omfs_add_node(struct inode *dir, struct dentry *dentry, int mode)
268 {
269         int err;
270         struct inode *inode = omfs_new_inode(dir, mode);
271
272         if (IS_ERR(inode))
273                 return PTR_ERR(inode);
274
275         err = omfs_make_empty(inode, dir->i_sb);
276         if (err)
277                 goto out_free_inode;
278
279         err = omfs_add_link(dentry, inode);
280         if (err)
281                 goto out_free_inode;
282
283         d_instantiate(dentry, inode);
284         return 0;
285
286 out_free_inode:
287         iput(inode);
288         return err;
289 }
290
291 static int omfs_mkdir(struct inode *dir, struct dentry *dentry, int mode)
292 {
293         return omfs_add_node(dir, dentry, mode | S_IFDIR);
294 }
295
296 static int omfs_create(struct inode *dir, struct dentry *dentry, int mode,
297                 struct nameidata *nd)
298 {
299         return omfs_add_node(dir, dentry, mode | S_IFREG);
300 }
301
302 static struct dentry *omfs_lookup(struct inode *dir, struct dentry *dentry,
303                                   struct nameidata *nd)
304 {
305         struct buffer_head *bh;
306         struct inode *inode = NULL;
307
308         if (dentry->d_name.len > OMFS_NAMELEN)
309                 return ERR_PTR(-ENAMETOOLONG);
310
311         bh = omfs_find_entry(dir, dentry->d_name.name, dentry->d_name.len);
312         if (!IS_ERR(bh)) {
313                 struct omfs_inode *oi = (struct omfs_inode *)bh->b_data;
314                 ino_t ino = be64_to_cpu(oi->i_head.h_self);
315                 brelse(bh);
316                 inode = omfs_iget(dir->i_sb, ino);
317                 if (IS_ERR(inode))
318                         return ERR_CAST(inode);
319         }
320         d_add(dentry, inode);
321         return NULL;
322 }
323
324 /* sanity check block's self pointer */
325 int omfs_is_bad(struct omfs_sb_info *sbi, struct omfs_header *header,
326         u64 fsblock)
327 {
328         int is_bad;
329         u64 ino = be64_to_cpu(header->h_self);
330         is_bad = ((ino != fsblock) || (ino < sbi->s_root_ino) ||
331                 (ino > sbi->s_num_blocks));
332
333         if (is_bad)
334                 printk(KERN_WARNING "omfs: bad hash chain detected\n");
335
336         return is_bad;
337 }
338
339 static int omfs_fill_chain(struct file *filp, void *dirent, filldir_t filldir,
340                 u64 fsblock, int hindex)
341 {
342         struct inode *dir = filp->f_dentry->d_inode;
343         struct buffer_head *bh;
344         struct omfs_inode *oi;
345         u64 self;
346         int res = 0;
347         unsigned char d_type;
348
349         /* follow chain in this bucket */
350         while (fsblock != ~0) {
351                 bh = omfs_bread(dir->i_sb, fsblock);
352                 if (!bh)
353                         goto out;
354
355                 oi = (struct omfs_inode *) bh->b_data;
356                 if (omfs_is_bad(OMFS_SB(dir->i_sb), &oi->i_head, fsblock)) {
357                         brelse(bh);
358                         goto out;
359                 }
360
361                 self = fsblock;
362                 fsblock = be64_to_cpu(oi->i_sibling);
363
364                 /* skip visited nodes */
365                 if (hindex) {
366                         hindex--;
367                         brelse(bh);
368                         continue;
369                 }
370
371                 d_type = (oi->i_type == OMFS_DIR) ? DT_DIR : DT_REG;
372
373                 res = filldir(dirent, oi->i_name, strnlen(oi->i_name,
374                         OMFS_NAMELEN), filp->f_pos, self, d_type);
375                 if (res == 0)
376                         filp->f_pos++;
377                 brelse(bh);
378         }
379 out:
380         return res;
381 }
382
383 static int omfs_rename(struct inode *old_dir, struct dentry *old_dentry,
384                 struct inode *new_dir, struct dentry *new_dentry)
385 {
386         struct inode *new_inode = new_dentry->d_inode;
387         struct inode *old_inode = old_dentry->d_inode;
388         struct buffer_head *bh;
389         int is_dir;
390         int err;
391
392         is_dir = S_ISDIR(old_inode->i_mode);
393
394         if (new_inode) {
395                 /* overwriting existing file/dir */
396                 err = -ENOTEMPTY;
397                 if (is_dir && !omfs_dir_is_empty(new_inode))
398                         goto out;
399
400                 err = -ENOENT;
401                 bh = omfs_find_entry(new_dir, new_dentry->d_name.name,
402                         new_dentry->d_name.len);
403                 if (IS_ERR(bh))
404                         goto out;
405                 brelse(bh);
406
407                 err = omfs_unlink(new_dir, new_dentry);
408                 if (err)
409                         goto out;
410         }
411
412         /* since omfs locates files by name, we need to unlink _before_
413          * adding the new link or we won't find the old one */
414         inode_inc_link_count(old_inode);
415         err = omfs_delete_entry(old_dentry);
416         if (err)
417                 goto out;
418
419         mark_inode_dirty(old_dir);
420         err = omfs_add_link(new_dentry, old_inode);
421         if (err)
422                 goto out;
423
424         old_inode->i_ctime = CURRENT_TIME_SEC;
425         mark_inode_dirty(old_inode);
426 out:
427         return err;
428 }
429
430 static int omfs_readdir(struct file *filp, void *dirent, filldir_t filldir)
431 {
432         struct inode *dir = filp->f_dentry->d_inode;
433         struct buffer_head *bh;
434         loff_t offset, res;
435         unsigned int hchain, hindex;
436         int nbuckets;
437         u64 fsblock;
438         int ret = -EINVAL;
439
440         if (filp->f_pos >> 32)
441                 goto success;
442
443         switch ((unsigned long) filp->f_pos) {
444         case 0:
445                 if (filldir(dirent, ".", 1, 0, dir->i_ino, DT_DIR) < 0)
446                         goto success;
447                 filp->f_pos++;
448                 /* fall through */
449         case 1:
450                 if (filldir(dirent, "..", 2, 1,
451                     parent_ino(filp->f_dentry), DT_DIR) < 0)
452                         goto success;
453                 filp->f_pos = 1 << 20;
454                 /* fall through */
455         }
456
457         nbuckets = (dir->i_size - OMFS_DIR_START) / 8;
458
459         /* high 12 bits store bucket + 1 and low 20 bits store hash index */
460         hchain = (filp->f_pos >> 20) - 1;
461         hindex = filp->f_pos & 0xfffff;
462
463         bh = omfs_bread(dir->i_sb, dir->i_ino);
464         if (!bh)
465                 goto out;
466
467         offset = OMFS_DIR_START + hchain * 8;
468
469         for (; hchain < nbuckets; hchain++, offset += 8) {
470                 fsblock = be64_to_cpu(*((__be64 *) &bh->b_data[offset]));
471
472                 res = omfs_fill_chain(filp, dirent, filldir, fsblock, hindex);
473                 hindex = 0;
474                 if (res < 0)
475                         break;
476
477                 filp->f_pos = (hchain+2) << 20;
478         }
479         brelse(bh);
480 success:
481         ret = 0;
482 out:
483         return ret;
484 }
485
486 const struct inode_operations omfs_dir_inops = {
487         .lookup = omfs_lookup,
488         .mkdir = omfs_mkdir,
489         .rename = omfs_rename,
490         .create = omfs_create,
491         .unlink = omfs_unlink,
492         .rmdir = omfs_rmdir,
493 };
494
495 const struct file_operations omfs_dir_operations = {
496         .read = generic_read_dir,
497         .readdir = omfs_readdir,
498         .llseek = generic_file_llseek,
499 };