Whamcloud - gitweb
Updated for new obdo methods.
[fs/lustre-release.git] / lustre / obdfs / namei.c
1 /*
2  *  linux/fs/obdfs/namei.c
3  *
4  * Copyright (C) 1992, 1993, 1994, 1995
5  * Remy Card (card@masi.ibp.fr)
6  * Laboratoire MASI - Institut Blaise Pascal
7  * Universite Pierre et Marie Curie (Paris VI)
8  *
9  *  from
10  *
11  *  linux/fs/ext2/namei.c
12  *
13  *  Copyright (C) 1991, 1992  Linus Torvalds
14  *
15  *  Big-endian to little-endian byte-swapping/bitmaps by
16  *        David S. Miller (davem@caip.rutgers.edu), 1995
17  *  Directory entry file type support and forward compatibility hooks
18  *      for B-tree directories by Theodore Ts'o (tytso@mit.edu), 1998
19  * 
20  *  Changes for use in OBDFS
21  *  Copyright (c) 1999, Seagate Technology Inc.
22  * 
23  */
24
25 #include <asm/uaccess.h>
26
27 #include <linux/errno.h>
28 #include <linux/fs.h>
29 #include <linux/ext2_fs.h>
30 #include <linux/fcntl.h>
31 #include <linux/sched.h>
32 #include <linux/stat.h>
33 #include <linux/string.h>
34 #include <linux/locks.h>
35 #include <linux/quotaops.h>
36 #include <linux/iobuf.h>
37
38 #include <linux/obd_support.h>
39 #include <linux/obdfs.h>
40
41 /*
42  * define how far ahead to read directories while searching them.
43  */
44 #define NAMEI_RA_CHUNKS  2
45 #define NAMEI_RA_BLOCKS  4
46 #define NAMEI_RA_SIZE        (NAMEI_RA_CHUNKS * NAMEI_RA_BLOCKS)
47 #define NAMEI_RA_INDEX(c,b)  (((c) * NAMEI_RA_BLOCKS) + (b))
48
49 /*
50  * NOTE! unlike strncmp, ext2_match returns 1 for success, 0 for failure.
51  *
52  * `len <= EXT2_NAME_LEN' is guaranteed by caller.
53  * `de != NULL' is guaranteed by caller.
54  */
55 static inline int ext2_match (int len, const char * const name,
56                        struct ext2_dir_entry_2 * de)
57 {
58         if (len != de->name_len)
59                 return 0;
60         if (!de->inode)
61                 return 0;
62         return !memcmp(name, de->name, len);
63 }
64
65 /*
66  *      ext2_find_entry()
67  *
68  * finds an entry in the specified directory with the wanted name. It
69  * returns the cache buffer in which the entry was found, and the entry
70  * itself (as a parameter - res_dir). It does NOT read the inode of the
71  * entry - you'll have to do that yourself if you want to.
72  */
73 static struct page * obdfs_find_entry (struct inode * dir,
74                                              const char * const name, int namelen,
75                                              struct ext2_dir_entry_2 ** res_dir, int lock)
76 {
77         struct super_block * sb;
78         unsigned long offset;
79         struct page * page;
80         ENTRY;
81         CDEBUG(D_INODE, "find entry for %*s\n", namelen, name);
82
83         *res_dir = NULL;
84         sb = dir->i_sb;
85
86         if (namelen > EXT2_NAME_LEN)
87                 return NULL;
88
89         CDEBUG(D_INODE, "dirsize is %Ld\n", dir->i_size);
90
91         page = 0;
92         offset = 0;
93         while ( offset < dir->i_size ) {
94                 struct ext2_dir_entry_2 * de;
95                 char * dlimit;
96
97                 page = obdfs_getpage(dir, offset, 0, lock);
98
99                 if ( !page ) {
100                         CDEBUG(D_INODE, "No page, offset %lx\n", offset);
101                         return NULL;
102                 }
103
104                 de = (struct ext2_dir_entry_2 *) page_address(page);
105                 dlimit = (char *)page_address(page) + PAGE_SIZE; 
106                 while ((char *) de < dlimit) {
107                         /* this code is executed quadratically often */
108                         /* do minimal checking `by hand' */
109                         int de_len;
110                         /* CDEBUG(D_INODE, "Entry %p len %d, page at %#lx - %#lx , offset %lx\n",
111                                de, le16_to_cpu(de->rec_len), page_address(page),
112                                page_address(page) + PAGE_SIZE, offset); */
113
114                         if ((char *) de + namelen <= dlimit &&
115                             ext2_match (namelen, name, de)) {
116                                 /* found a match -
117                                    just to be sure, do a full check */
118                                 if (!obdfs_check_dir_entry("ext2_find_entry",
119                                                           dir, de, page, offset))
120                                         goto failure;
121                                 *res_dir = de;
122                                 EXIT;
123                                 return page;
124                         }
125                         /* prevent looping on a bad block */
126                         de_len = le16_to_cpu(de->rec_len);
127                         if (de_len <= 0) {
128                                 printk("Bad entry at %p len %d\n", de, de_len);
129                                 goto failure;
130                         }
131                         offset += de_len;
132                         de = (struct ext2_dir_entry_2 *)
133                                 ((char *) de + de_len);
134                         /* CDEBUG(D_INODE, "Next while %lx\n", offset); */
135                 }
136                 if ( lock ) 
137                         UnlockPage(page);
138                 page_cache_release(page);
139                 page = NULL;
140                 CDEBUG(D_INODE, "Next for %lx\n", offset);
141         }
142
143 failure:
144         CDEBUG(D_INODE, "Negative case, page %p, offset %ld\n", page, offset);
145         if (page) {
146                 if (lock) 
147                         UnlockPage(page);
148                 page_cache_release(page);
149         }
150         EXIT;
151         return NULL;
152 }
153
154 struct dentry *obdfs_lookup(struct inode * dir, struct dentry *dentry)
155 {
156         struct inode * inode;
157         struct ext2_dir_entry_2 * de;
158         struct page * page;
159         ENTRY;
160
161         if (dentry->d_name.len > EXT2_NAME_LEN)
162                 return ERR_PTR(-ENAMETOOLONG);
163
164         page = obdfs_find_entry (dir, dentry->d_name.name, dentry->d_name.len, &de, LOCKED);
165         inode = NULL;
166         if ( !page ) 
167                 CDEBUG(D_INODE, "No page - negative entry.\n");
168         if ( page && !de ) {
169                 CDEBUG(D_INODE, "Danger: PAGE but de.\n");
170                 return ERR_PTR(-ENOENT);
171         }
172         if (page) {
173                 unsigned long ino = le32_to_cpu(de->inode);
174                 UnlockPage(page);
175                 page_cache_release(page);
176                 inode = iget(dir->i_sb, ino);
177
178                 if (!inode) { 
179                         CDEBUG(D_INODE, "No inode.\n");
180                         EXIT;
181                         return ERR_PTR(-EACCES);
182                 }
183         }
184         d_add(dentry, inode);
185         EXIT;
186         return NULL;
187 }
188
189
190 /*
191  *      ext2_add_entry()
192  *
193  * adds a file entry to the specified directory, using the same
194  * semantics as ext2_find_entry(). It returns NULL if it failed.
195  *
196  * NOTE!! The inode part of 'de' is left at 0 - which means you
197  * may not sleep between calling this and putting something into
198  * the entry, as someone else might have used it while you slept.
199
200  * returns a locked and held page upon success 
201  */
202
203 /* XXX I believe these pages should in fact NOT be locked */
204
205 static struct page *obdfs_add_entry (struct inode * dir,
206                                      const char * name, int namelen,
207                                      struct ext2_dir_entry_2 ** res_dir,
208                                      int *err)
209 {
210         unsigned long offset;
211         unsigned short rec_len;
212         struct page *page;
213         struct ext2_dir_entry_2 * de, * de1;
214         struct super_block * sb;
215
216         ENTRY;
217         *err = -EINVAL;
218         *res_dir = NULL;
219         if (!dir || !dir->i_nlink) {
220                 EXIT;
221                 return NULL;
222         }
223         sb = dir->i_sb;
224
225         if (!namelen) { 
226                 EXIT;
227                 return NULL;
228         }
229         /*
230          * Is this a busy deleted directory?  Can't create new files if so
231          */
232         if (dir->i_size == 0)
233         {
234                 EXIT;
235                 *err = -ENOENT;
236                 return NULL;
237         }
238         page = obdfs_getpage(dir, 0, 0, LOCKED);
239         if (!page) {
240                 EXIT;
241                 return NULL;
242         }
243         rec_len = EXT2_DIR_REC_LEN(namelen);
244         CDEBUG(D_INODE, "reclen: %d\n", rec_len);
245         offset = 0;
246         de = (struct ext2_dir_entry_2 *) page_address(page);
247         *err = -ENOSPC;
248         while (1) {
249                 CDEBUG(D_INODE, "Considering entry at %p, (page at %#lx - %#lx), offset %ld\n",
250                        de, page_address(page), page_address(page) + PAGE_SIZE, offset);
251                 if ((char *)de >= PAGE_SIZE + (char *)page_address(page)) {
252                         UnlockPage(page);
253                         page_cache_release(page);
254                         page = obdfs_getpage(dir, offset, 1, LOCKED);
255                         if (!page) {
256                                 EXIT;
257                                 return NULL;
258                         }
259                         if (dir->i_size <= offset) {
260                                 if (dir->i_size == 0) {
261                                         *err = -ENOENT;
262                                         EXIT;
263                                         return NULL;
264                                 }
265
266                                 CDEBUG(D_INODE, "creating next block\n");
267
268                                 de = (struct ext2_dir_entry_2 *) page_address(page);
269                                 de->inode = 0;
270                                 de->rec_len = le16_to_cpu(PAGE_SIZE);
271                                 dir->i_size = offset + PAGE_SIZE;
272                                 dir->u.ext2_i.i_flags &= ~EXT2_BTREE_FL;
273                                 mark_inode_dirty(dir);
274                         } else {
275
276                                 ext2_debug ("skipping to next block\n");
277
278                                 de = (struct ext2_dir_entry_2 *) page_address(page);
279                         }
280                 }
281                 CDEBUG(D_INODE, "\n");
282                 if (!obdfs_check_dir_entry ("ext2_add_entry", dir, de, page,
283                                            offset)) {
284                         *err = -ENOENT;
285                         UnlockPage(page);
286                         page_cache_release(page);
287                         EXIT;
288                         return NULL;
289                 }
290                 CDEBUG(D_INODE, "\n");
291                 if (ext2_match (namelen, name, de)) {
292                                 *err = -EEXIST;
293                                 UnlockPage(page);
294                                 page_cache_release(page);
295                                 EXIT;
296                                 return NULL;
297                 }
298                 CDEBUG(D_INODE, "Testing for enough space at de %p\n", de);
299                 if ( (le32_to_cpu(de->inode) == 0 && le16_to_cpu(de->rec_len) >= rec_len) ||
300                      (le16_to_cpu(de->rec_len) >= EXT2_DIR_REC_LEN(de->name_len) + rec_len)) {
301                         offset += le16_to_cpu(de->rec_len);
302                         CDEBUG(D_INODE, "Found enough space de %p, offset %#lx\n", de, offset);
303                         if (le32_to_cpu(de->inode)) {
304                                 CDEBUG(D_INODE, "Inserting new in %p\n", de);
305                                 de1 = (struct ext2_dir_entry_2 *) ((char *) de +
306                                         EXT2_DIR_REC_LEN(de->name_len));
307                                 CDEBUG(D_INODE, "-- de1 at %p\n", de1);
308                                 de1->rec_len = cpu_to_le16(le16_to_cpu(de->rec_len) -
309                                         EXT2_DIR_REC_LEN(de->name_len));
310                                 de->rec_len = cpu_to_le16(EXT2_DIR_REC_LEN(de->name_len));
311                                 de = de1;
312                         }
313                         CDEBUG(D_INODE, "Reclen adjusted; copy %d bytes to %p, page at %#lx EOP at %#lx\n", namelen, de->name, page_address(page), page_address(page) + PAGE_SIZE);
314                         de->inode = 0;
315                         de->name_len = namelen;
316                         de->file_type = 0;
317                         memcpy (de->name, name, namelen);
318                         CDEBUG(D_INODE, "Copy done\n");
319                         /*
320                          * XXX shouldn't update any times until successful
321                          * completion of syscall, but too many callers depend
322                          * on this.
323                          *
324                          * XXX similarly, too many callers depend on
325                          * ext2_new_inode() setting the times, but error
326                          * recovery deletes the inode, so the worst that can
327                          * happen is that the times are slightly out of date
328                          * and/or different from the directory change time.
329                          */
330                         dir->i_mtime = dir->i_ctime = CURRENT_TIME;
331                         dir->u.ext2_i.i_flags &= ~EXT2_BTREE_FL;
332                         mark_inode_dirty(dir);
333                         dir->i_version = ++event;
334                         *res_dir = de;
335                         *err = 0;
336                         PDEBUG(page, "addentry");
337                         CDEBUG(D_INODE, "Regular exit from add_entry");
338                         EXIT;
339                         return page;
340                 }
341                 CDEBUG(D_INODE, "\n");
342                 offset += le16_to_cpu(de->rec_len);
343                 de = (struct ext2_dir_entry_2 *) ((char *) de + le16_to_cpu(de->rec_len));
344                 
345         }
346         CDEBUG(D_INODE, "\n");
347
348         UnlockPage(page);
349         page_cache_release(page);
350         PDEBUG(page, "addentry");
351         EXIT;
352         return NULL;
353 }
354
355 /*
356  * ext2_delete_entry deletes a directory entry by merging it with the
357  * previous entry
358  */
359 static int obdfs_delete_entry (struct ext2_dir_entry_2 * dir,
360                               struct page * page)
361 {
362         struct ext2_dir_entry_2 * de, * pde;
363         int i;
364
365         i = 0;
366         pde = NULL;
367         de = (struct ext2_dir_entry_2 *) page_address(page);
368         while (i < PAGE_SIZE) {
369                 if (!obdfs_check_dir_entry ("ext2_delete_entry", NULL, 
370                                            de, page, i))
371                         return -EIO;
372                 if (de == dir)  {
373                         if (pde)
374                                 pde->rec_len =
375                                         cpu_to_le16(le16_to_cpu(pde->rec_len) +
376                                                     le16_to_cpu(dir->rec_len));
377                         else
378                                 dir->inode = 0;
379                         return 0;
380                 }
381                 i += le16_to_cpu(de->rec_len);
382                 pde = de;
383                 de = (struct ext2_dir_entry_2 *) ((char *) de + le16_to_cpu(de->rec_len));
384         }
385         return -ENOENT;
386 }
387
388
389 static inline void ext2_set_de_type(struct super_block *sb,
390                                 struct ext2_dir_entry_2 *de,
391                                 umode_t mode) {
392         if (!EXT2_HAS_INCOMPAT_FEATURE(sb, EXT2_FEATURE_INCOMPAT_FILETYPE))
393                 return;
394         if (S_ISCHR(mode))
395                 de->file_type = EXT2_FT_CHRDEV;
396         else if (S_ISBLK(mode))
397                 de->file_type = EXT2_FT_BLKDEV;
398         else if (S_ISFIFO(mode))  
399                 de->file_type = EXT2_FT_FIFO;
400         else if (S_ISLNK(mode))
401                 de->file_type = EXT2_FT_SYMLINK;
402         else if (S_ISREG(mode))
403                 de->file_type = EXT2_FT_REG_FILE;
404         else if (S_ISDIR(mode))  
405                 de->file_type = EXT2_FT_DIR;
406 }
407
408
409 /*
410  * Display all dentries holding the specified inode.
411  */
412 #if 0
413 static void show_dentry(struct list_head * dlist, int subdirs)
414 {
415         struct list_head *tmp = dlist;
416
417         while ((tmp = tmp->next) != dlist) {
418                 struct dentry * dentry;
419                 const char * unhashed = "";
420
421                 if ( subdirs ) 
422                         dentry  = list_entry(tmp, struct dentry, d_child);
423                 else 
424                         dentry  = list_entry(tmp, struct dentry, d_alias);
425
426                 if (list_empty(&dentry->d_hash))
427                         unhashed = "(unhashed)";
428
429                 if ( dentry->d_inode ) 
430                         printk("show_dentry: %s/%s, d_count=%d%s (ino %ld, dev %d, ct %d)\n",
431                                dentry->d_parent->d_name.name,
432                                dentry->d_name.name, dentry->d_count,
433                                unhashed, dentry->d_inode->i_ino, 
434                                dentry->d_inode->i_dev, 
435                                dentry->d_inode->i_count);
436                 else 
437                         printk("show_dentry: %s/%s, d_count=%d%s \n",
438                                dentry->d_parent->d_name.name,
439                                dentry->d_name.name, dentry->d_count,
440                                unhashed);
441         }
442 }
443 #endif
444
445
446 struct inode *obdfs_new_inode(struct inode *dir)
447 {
448         struct obdo *obdo;
449         struct inode *inode;
450         int err;
451
452         obdo = obdo_alloc();
453         if (!obdo) {
454                 EXIT;
455                 return ERR_PTR(-ENOMEM);
456         }
457
458         err = IOPS(dir, create)(IID(dir), obdo);
459         if ( err ) 
460                 return ERR_PTR(err);
461
462         inode = iget(dir->i_sb, (unsigned long)obdo->o_id);
463         if (!inode) {
464                 obdo_free(obdo);
465                 EXIT;
466                 return ERR_PTR(-EIO);
467         }
468
469         if (!list_empty(&inode->i_dentry)) {
470                 CDEBUG(D_INODE, "New inode (%ld) has aliases!\n", 
471                        inode->i_ino);
472                 iput(inode);
473                 EXIT;
474                 return ERR_PTR(-EIO);
475         }
476
477
478         obdo_free(obdo);
479         EXIT;
480         return inode;
481 }
482
483
484 /*
485  * By the time this is called, we already have created
486  * the directory cache entry for the new file, but it
487  * is so far negative - it has no inode.
488  *
489  * If the create succeeds, we fill in the inode information
490  * with d_instantiate(). 
491  */
492 int obdfs_create (struct inode * dir, struct dentry * dentry, int mode)
493 {
494         struct inode * inode;
495         struct page *page;
496         struct ext2_dir_entry_2 * de;
497         int err = -EIO;
498
499         ENTRY;
500
501         inode = obdfs_new_inode(dir);
502         if ( IS_ERR(inode) ) {
503                 EXIT;
504                 return PTR_ERR(inode);
505         }
506
507         inode->i_op = &obdfs_file_inode_operations;
508         inode->i_mode = mode;
509         mark_inode_dirty(inode);
510         page = obdfs_add_entry (dir, dentry->d_name.name, dentry->d_name.len, &de, &err);
511         if (!page) {
512                 inode->i_nlink--;
513                 mark_inode_dirty(inode);
514                 iput (inode);
515                 EXIT;
516                 return err;
517         }
518         de->inode = cpu_to_le32(inode->i_ino);
519         ext2_set_de_type(dir->i_sb, de, S_IFREG);
520         dir->i_version = ++event;
521
522         err = obdfs_do_writepage(dir, page, IS_SYNC(dir));
523         UnlockPage(page);
524
525         page_cache_release(page);
526         d_instantiate(dentry, inode);
527         EXIT;
528         return err;
529 }
530
531 int obdfs_mknod (struct inode * dir, struct dentry *dentry, int mode, int rdev)
532 {
533         struct inode * inode;
534         struct page *page;
535         struct ext2_dir_entry_2 * de;
536         int err;
537
538         ENTRY;
539
540         inode = obdfs_new_inode(dir);
541         if ( IS_ERR(inode) ) {
542                 EXIT;
543                 return PTR_ERR(inode);
544         }
545
546         inode->i_uid = current->fsuid;
547         init_special_inode(inode, mode, rdev);
548         page = obdfs_add_entry (dir, dentry->d_name.name, dentry->d_name.len, &de, &err);
549         if (!page)
550                 goto out_no_entry;
551         de->inode = cpu_to_le32(inode->i_ino);
552         dir->i_version = ++event;
553         ext2_set_de_type(dir->i_sb, de, inode->i_mode);
554         mark_inode_dirty(inode);
555
556         err = obdfs_do_writepage(dir, page, IS_SYNC(dir));
557         UnlockPage(page);
558
559         d_instantiate(dentry, inode);
560         page_cache_release(page);
561         err = 0;
562 out:
563         return err;
564
565 out_no_entry:
566         inode->i_nlink--;
567         mark_inode_dirty(inode);
568         iput(inode);
569         goto out;
570 }
571
572 int obdfs_mkdir(struct inode * dir, struct dentry * dentry, int mode)
573 {
574         struct inode * inode;
575         struct page *page, *inode_page;
576         struct ext2_dir_entry_2 * de;
577         int err;
578
579         ENTRY;
580
581         err = -EMLINK;
582         if (dir->i_nlink >= EXT2_LINK_MAX)
583                 goto out;
584
585         inode = obdfs_new_inode(dir);
586         if ( IS_ERR(inode) ) {
587                 EXIT;
588                 return PTR_ERR(inode);
589         }
590
591         inode->i_op = &obdfs_dir_inode_operations;
592         inode->i_blocks = 0;    
593         inode_page = obdfs_getpage(inode, 0, 1, LOCKED);
594         if (!inode_page) {
595                 inode->i_nlink--; /* is this nlink == 0? */
596                 mark_inode_dirty(inode);
597                 iput (inode);
598                 return err;
599         }
600
601         /* create . and .. */
602         de = (struct ext2_dir_entry_2 *) page_address(inode_page);
603         de->inode = cpu_to_le32(inode->i_ino);
604         de->name_len = 1;
605         de->rec_len = cpu_to_le16(EXT2_DIR_REC_LEN(de->name_len));
606         strcpy (de->name, ".");
607         ext2_set_de_type(dir->i_sb, de, S_IFDIR);
608         
609         de = (struct ext2_dir_entry_2 *) ((char *) de + le16_to_cpu(de->rec_len));
610         de->inode = cpu_to_le32(dir->i_ino);
611         de->rec_len = cpu_to_le16(PAGE_SIZE - EXT2_DIR_REC_LEN(1));
612         de->name_len = 2;
613         strcpy (de->name, "..");
614         ext2_set_de_type(dir->i_sb, de, S_IFDIR);
615         
616         err = obdfs_do_writepage(inode, inode_page, IS_SYNC(inode));
617         inode->i_blocks = PAGE_SIZE/inode->i_sb->s_blocksize;
618         inode->i_size = PAGE_SIZE;
619         UnlockPage(inode_page);
620         page_cache_release(inode_page);
621         /* XXX handle err */
622
623         inode->i_nlink = 2;
624         inode->i_mode = S_IFDIR | mode;
625         if (dir->i_mode & S_ISGID)
626                 inode->i_mode |= S_ISGID;
627         mark_inode_dirty(inode);
628
629         /* now deal with the parent */
630         page = obdfs_add_entry(dir, dentry->d_name.name, dentry->d_name.len, &de, &err);
631         if (!page) {
632                 goto out_no_entry;
633         }
634
635         de->inode = cpu_to_le32(inode->i_ino);
636         ext2_set_de_type(dir->i_sb, de, S_IFDIR);
637         dir->i_version = ++event;
638
639         dir->i_nlink++;
640         dir->u.ext2_i.i_flags &= ~EXT2_BTREE_FL;
641         mark_inode_dirty(dir);
642         err = obdfs_do_writepage(dir, page, IS_SYNC(dir));
643
644         UnlockPage(page);
645
646         page_cache_release(page);
647         d_instantiate(dentry, inode);
648         err = 0;
649 out:
650         EXIT;
651         return err;
652
653 out_no_entry:
654         inode->i_nlink = 0;
655         mark_inode_dirty(inode);
656         iput (inode);
657         EXIT;
658         goto out;
659 }
660
661
662 /*
663  * routine to check that the specified directory is empty (for rmdir)
664  */
665 static int empty_dir (struct inode * inode)
666 {
667         unsigned long offset;
668         struct page *page;
669         struct ext2_dir_entry_2 * de, * de1;
670         struct super_block * sb;
671
672         sb = inode->i_sb;
673         if (inode->i_size < EXT2_DIR_REC_LEN(1) + EXT2_DIR_REC_LEN(2) ||
674             !(page = obdfs_getpage (inode, 0, 0, LOCKED))) {
675                 ext2_warning (inode->i_sb, "empty_dir",
676                               "bad directory (dir #%lu) - no data block",
677                               inode->i_ino);
678                 return 1;
679         }
680         de = (struct ext2_dir_entry_2 *) page_address(page);
681         de1 = (struct ext2_dir_entry_2 *) ((char *) de + le16_to_cpu(de->rec_len));
682         if (le32_to_cpu(de->inode) != inode->i_ino || !le32_to_cpu(de1->inode) || 
683             strcmp (".", de->name) || strcmp ("..", de1->name)) {
684                 ext2_warning (inode->i_sb, "empty_dir",
685                               "bad directory (dir #%lu) - no `.' or `..'",
686                               inode->i_ino);
687                 page_cache_release(page);
688                 return 1;
689         }
690         offset = le16_to_cpu(de->rec_len) + le16_to_cpu(de1->rec_len);
691         de = (struct ext2_dir_entry_2 *) ((char *) de1 + le16_to_cpu(de1->rec_len));
692         while (offset < inode->i_size ) {
693                 if (!page || (void *) de >= (void *) (page_address(page) + PAGE_SIZE)) {
694                         if (page) {
695                                 UnlockPage(page);
696                                 page_cache_release(page);
697                         }
698                         page = obdfs_getpage(inode, offset, 0, LOCKED);
699                         if (!page) {
700 #if 0
701                                 ext2_error (sb, "empty_dir",
702                                             "directory #%lu contains a hole at offset %lu",
703                                             inode->i_ino, offset);
704 #endif
705                                 offset += sb->s_blocksize;
706                                 continue;
707                         }
708                         de = (struct ext2_dir_entry_2 *) page_address(page);
709                 }
710                 if (!obdfs_check_dir_entry ("empty_dir", inode, de, page,
711                                            offset)) {
712                         UnlockPage(page);
713                         page_cache_release(page);
714                         return 1;
715                 }
716                 if (le32_to_cpu(de->inode)) {
717                         UnlockPage(page);
718                         page_cache_release(page);
719                         return 0;
720                 }
721                 offset += le16_to_cpu(de->rec_len);
722                 de = (struct ext2_dir_entry_2 *) ((char *) de + le16_to_cpu(de->rec_len));
723         }
724         UnlockPage(page);
725         page_cache_release(page);
726         return 1;
727 }
728
729 int obdfs_rmdir (struct inode * dir, struct dentry *dentry)
730 {
731         int retval;
732         struct inode * inode;
733         struct page *page;
734         struct ext2_dir_entry_2 * de;
735         int err;
736
737         ENTRY;
738
739         retval = -ENOENT;
740         page = obdfs_find_entry (dir, dentry->d_name.name, dentry->d_name.len, &de, LOCKED);
741         if (!page)
742                 goto end_rmdir;
743
744         inode = dentry->d_inode;
745         DQUOT_INIT(inode);
746
747         retval = -EIO;
748         if (le32_to_cpu(de->inode) != inode->i_ino)
749                 goto end_rmdir;
750
751         retval = -ENOTEMPTY;
752         if (!empty_dir (inode))
753                 goto end_rmdir;
754
755         retval = obdfs_delete_entry (de, page);
756         dir->i_version = ++event;
757         if (retval)
758                 goto end_rmdir;
759         err = obdfs_do_writepage(dir, page, IS_SYNC(dir));
760         UnlockPage(page);
761
762         if (inode->i_nlink != 2)
763                 ext2_warning (inode->i_sb, "ext2_rmdir",
764                               "empty directory has nlink!=2 (%d)",
765                               inode->i_nlink);
766         inode->i_version = ++event;
767         inode->i_nlink = 0;
768         inode->i_size = 0;
769         mark_inode_dirty(inode);
770         dir->i_nlink--;
771         inode->i_ctime = dir->i_ctime = dir->i_mtime = CURRENT_TIME;
772         dir->u.ext2_i.i_flags &= ~EXT2_BTREE_FL;
773         mark_inode_dirty(dir);
774         d_delete(dentry);
775
776 end_rmdir:
777         if ( page )
778                 page_cache_release(page);
779         EXIT;
780         return retval;
781 }
782
783 int obdfs_unlink(struct inode * dir, struct dentry *dentry)
784 {
785         int retval;
786         struct inode * inode;
787         struct page *page;
788         struct ext2_dir_entry_2 * de;
789         int err;
790
791         ENTRY;
792
793         retval = -ENOENT;
794         page = obdfs_find_entry (dir, dentry->d_name.name, dentry->d_name.len, &de, LOCKED);
795         if (!page)
796                 goto end_unlink;
797
798         inode = dentry->d_inode;
799         DQUOT_INIT(inode);
800
801         retval = -EIO;
802         if (le32_to_cpu(de->inode) != inode->i_ino)
803                 goto end_unlink;
804         
805         if (!inode->i_nlink) {
806                 ext2_warning (inode->i_sb, "ext2_unlink",
807                               "Deleting nonexistent file (%lu), %d",
808                               inode->i_ino, inode->i_nlink);
809                 inode->i_nlink = 1;
810         }
811         retval = obdfs_delete_entry (de, page);
812         if (retval)
813                 goto end_unlink;
814         dir->i_version = ++event;
815         err = obdfs_do_writepage(dir, page, IS_SYNC(dir));
816         UnlockPage(page);
817
818         dir->i_ctime = dir->i_mtime = CURRENT_TIME;
819         dir->u.ext2_i.i_flags &= ~EXT2_BTREE_FL;
820         mark_inode_dirty(dir);
821         inode->i_nlink--;
822         mark_inode_dirty(inode);
823         inode->i_ctime = dir->i_ctime;
824         retval = 0;
825         d_delete(dentry);       /* This also frees the inode */
826
827 end_unlink:
828         if (page)
829                 page_cache_release(page);
830         EXIT;
831         return retval;
832 }
833
834 int obdfs_symlink (struct inode * dir, struct dentry *dentry, const char * symname)
835 {
836         struct ext2_dir_entry_2 * de;
837         struct inode * inode;
838         struct page* page = NULL, * name_page = NULL;
839         char * link;
840         int i, l, err = -EIO;
841         char c;
842
843         ENTRY;
844         inode = obdfs_new_inode(dir);
845         if ( IS_ERR(inode) ) {
846                 EXIT;
847                 return PTR_ERR(inode);
848         }
849
850         inode->i_mode = S_IFLNK | S_IRWXUGO;
851         inode->i_op = &obdfs_symlink_inode_operations;
852         for (l = 0; l < inode->i_sb->s_blocksize - 1 &&
853              symname [l]; l++)
854                 ;
855
856         if (l >= sizeof (inode->u.ext2_i.i_data)) {
857                 CDEBUG(D_INODE, "l=%d, normal symlink\n", l);
858
859                 name_page = obdfs_getpage(inode, 0, 1, LOCKED);
860                 if (!name_page) {
861                         inode->i_nlink--;
862                         mark_inode_dirty(inode);
863                         iput (inode);
864                         EXIT;
865                         return err;
866                 }
867                 link = (char *)page_address(name_page);
868         } else {
869                 link = (char *) inode->u.ext2_i.i_data;
870
871                 CDEBUG(D_INODE, "l=%d, fast symlink\n", l);
872
873         }
874         i = 0;
875         while (i < inode->i_sb->s_blocksize - 1 && (c = *(symname++)))
876                 link[i++] = c;
877         link[i] = 0;
878         if (name_page) {
879                 obdfs_do_writepage(inode, name_page, IS_SYNC(inode));
880                 PDEBUG(name_page, "symlink");
881                 UnlockPage(name_page);
882                 page_cache_release(name_page);
883         }
884         inode->i_size = i;
885         mark_inode_dirty(inode);
886
887         page = obdfs_add_entry (dir, dentry->d_name.name, dentry->d_name.len, &de, &err);
888         if (!page)
889                 goto out_no_entry;
890         de->inode = cpu_to_le32(inode->i_ino);
891         ext2_set_de_type(dir->i_sb, de, S_IFLNK);
892         dir->i_version = ++event;
893         obdfs_do_writepage(dir, page, IS_SYNC(dir));
894         UnlockPage(page);
895
896         d_instantiate(dentry, inode);
897         err = 0;
898 out:
899         EXIT;
900         return err;
901
902 out_no_entry:
903         inode->i_nlink--;
904         mark_inode_dirty(inode);
905         iput (inode);
906         goto out;
907 }
908
909 int obdfs_link (struct dentry * old_dentry,
910                 struct inode * dir, struct dentry *dentry)
911 {
912         struct inode *inode = old_dentry->d_inode;
913         struct ext2_dir_entry_2 * de;
914         struct page *page;
915         int err;
916
917         ENTRY;
918
919         if (S_ISDIR(inode->i_mode))
920                 return -EPERM;
921
922         if (inode->i_nlink >= EXT2_LINK_MAX)
923                 return -EMLINK;
924
925         page = obdfs_add_entry (dir, dentry->d_name.name, dentry->d_name.len, &de, &err);
926         if (!page)
927                 return err;
928
929         de->inode = cpu_to_le32(inode->i_ino);
930         ext2_set_de_type(dir->i_sb, de, inode->i_mode);
931         dir->i_version = ++event;
932
933         obdfs_do_writepage(dir, page, IS_SYNC(dir));
934         UnlockPage(page);
935
936         page_cache_release(page);
937         inode->i_nlink++;
938         inode->i_ctime = CURRENT_TIME;
939         mark_inode_dirty(inode);
940         inode->i_count++;
941         d_instantiate(dentry, inode);
942         return 0;
943 }
944
945 #define PARENT_INO(buffer) \
946         ((struct ext2_dir_entry_2 *) ((char *) buffer + \
947         le16_to_cpu(((struct ext2_dir_entry_2 *) buffer)->rec_len)))->inode
948
949 /*
950  * Anybody can rename anything with this: the permission checks are left to the
951  * higher-level routines.
952  */
953 int obdfs_rename (struct inode * old_dir, struct dentry *old_dentry,
954                            struct inode * new_dir, struct dentry *new_dentry)
955 {
956         struct inode * old_inode, * new_inode;
957         struct page * old_page, * new_page, * dir_page;
958         struct ext2_dir_entry_2 * old_de, * new_de;
959         int retval;
960
961         ENTRY;
962
963         new_page = dir_page = NULL;
964
965         /* does the old entry exist? - if not get out */
966         old_page = obdfs_find_entry (old_dir, old_dentry->d_name.name, old_dentry->d_name.len, &old_de, NOLOCK);
967         PDEBUG(old_page, "rename - old page");
968         /*
969          *  Check for inode number is _not_ due to possible IO errors.
970          *  We might rmdir the source, keep it as pwd of some process
971          *  and merrily kill the link to whatever was created under the
972          *  same name. Goodbye sticky bit ;-<
973          */
974         old_inode = old_dentry->d_inode;
975         retval = -ENOENT;
976         if (!old_page || le32_to_cpu(old_de->inode) != old_inode->i_ino)
977                 goto end_rename;
978
979         /* find new inode */
980         new_inode = new_dentry->d_inode;
981         new_page = obdfs_find_entry (new_dir, new_dentry->d_name.name,
982                                 new_dentry->d_name.len, &new_de, NOLOCK);
983         PDEBUG(new_page, "rename - new page ");
984         if (new_page) {
985                 if (!new_inode) {
986                         page_cache_release(new_page);
987                         new_page = NULL;
988                 } else {
989                         DQUOT_INIT(new_inode);
990                 }
991         }
992         /* in this case we to check more ... */
993         if (S_ISDIR(old_inode->i_mode)) {
994                 /* can only rename into empty new directory */
995                 if (new_inode) {
996                         retval = -ENOTEMPTY;
997                         if (!empty_dir (new_inode))
998                                 goto end_rename;
999                 }
1000                 retval = -EIO;
1001                 dir_page= obdfs_getpage (old_inode, 0, 0, LOCKED);
1002                 PDEBUG(dir_page, "rename dir page");
1003
1004                 if (!dir_page)
1005                         goto end_rename;
1006                 if (le32_to_cpu(PARENT_INO(page_address(dir_page))) != old_dir->i_ino)
1007                         goto end_rename;
1008                 retval = -EMLINK;
1009                 if (!new_inode && new_dir!=old_dir &&
1010                                 new_dir->i_nlink >= EXT2_LINK_MAX)
1011                         goto end_rename;
1012         }
1013         /* create the target dir entry */
1014         if (!new_page) {
1015                 new_page = obdfs_add_entry (new_dir, new_dentry->d_name.name,
1016                                         new_dentry->d_name.len, &new_de,
1017                                         &retval);
1018                 PDEBUG(new_page, "rename new page");
1019                 if (!new_page)
1020                         goto end_rename;
1021         }
1022         new_dir->i_version = ++event;
1023
1024         /*
1025          * remove the old entry
1026          */
1027         new_de->inode = le32_to_cpu(old_inode->i_ino);
1028         if (EXT2_HAS_INCOMPAT_FEATURE(new_dir->i_sb,
1029                                       EXT2_FEATURE_INCOMPAT_FILETYPE))
1030                 new_de->file_type = old_de->file_type;
1031         
1032         obdfs_delete_entry (old_de, old_page);
1033
1034         old_dir->i_version = ++event;
1035         if (new_inode) {
1036                 new_inode->i_nlink--;
1037                 new_inode->i_ctime = CURRENT_TIME;
1038                 mark_inode_dirty(new_inode);
1039         }
1040         old_dir->i_ctime = old_dir->i_mtime = CURRENT_TIME;
1041         old_dir->u.ext2_i.i_flags &= ~EXT2_BTREE_FL;
1042         mark_inode_dirty(old_dir);
1043         if (dir_page) {
1044                 PARENT_INO(page_address(dir_page)) = le32_to_cpu(new_dir->i_ino);
1045                 obdfs_do_writepage(old_inode, dir_page, IS_SYNC(old_inode));
1046                 old_dir->i_nlink--;
1047                 mark_inode_dirty(old_dir);
1048                 if (new_inode) {
1049                         new_inode->i_nlink--;
1050                         mark_inode_dirty(new_inode);
1051                 } else {
1052                         new_dir->i_nlink++;
1053                         new_dir->u.ext2_i.i_flags &= ~EXT2_BTREE_FL;
1054                         mark_inode_dirty(new_dir);
1055                 }
1056         }
1057         if ( old_page != new_page ) {
1058                 unsigned long index = old_page->index;
1059                 /* lock the old_page and release unlocked copy */
1060                 CDEBUG(D_INODE, "old_page at %p\n", old_page);
1061                 page_cache_release(old_page);
1062                 old_page = obdfs_getpage(old_dir, index >> PAGE_SHIFT, 0, LOCKED);
1063                 CDEBUG(D_INODE, "old_page at %p\n", old_page);
1064                 obdfs_do_writepage(old_dir, old_page, IS_SYNC(old_dir));
1065         }
1066
1067         obdfs_do_writepage(new_dir, new_page, IS_SYNC(new_dir));
1068
1069         retval = 0;
1070
1071 end_rename:
1072         if (old_page && PageLocked(old_page) )
1073                 UnlockPage(old_page);
1074         if (old_page)
1075                 page_cache_release(old_page);
1076         if (new_page && PageLocked(new_page) )
1077                 UnlockPage(new_page);
1078         if (new_page)
1079                 page_cache_release(new_page);
1080         if (dir_page && PageLocked(dir_page) )
1081                 UnlockPage(dir_page);
1082         if (dir_page)
1083                 page_cache_release(dir_page);
1084
1085
1086         return retval;
1087 }