root/fs/inode.c

/* */

DEFINITIONS

1. hashfn
2. insert_inode_free
3. remove_inode_free
4. insert_inode_hash
5. remove_inode_hash
6. put_last_free
7. grow_inodes
8. inode_init
9. wait_on_inode
10. lock_inode
11. unlock_inode
12. clear_inode
13. fs_may_mount
14. fs_may_umount
15. fs_may_remount_ro
16. write_inode
17. read_inode
18. notify_change
19. bmap
20. invalidate_inodes
21. sync_inodes
22. iput
23. get_empty_inode
24. get_pipe_inode
25. iget
26. __iget
27. __wait_on_inode

   1 /*
   2  *  linux/fs/inode.c
   3  *
   4  *  Copyright (C) 1991, 1992  Linus Torvalds
   5  */
   6 
   7 #include <linux/stat.h>
   8 #include <linux/sched.h>
   9 #include <linux/kernel.h>
  10 #include <linux/mm.h>
  11 #include <linux/string.h>
  12 
  13 #include <asm/system.h>
  14 
  15 static struct inode_hash_entry {
  16         struct inode * inode;
  17         int updating;
  18 } hash_table[NR_IHASH];
  19 
  20 static struct inode * first_inode;
  21 static struct wait_queue * inode_wait = NULL;
  22 static int nr_inodes = 0, nr_free_inodes = 0;
  23 
  24 static inline int const hashfn(dev_t dev, unsigned int i)
     /*  */
  25 {
  26         return (dev ^ i) % NR_IHASH;
  27 }
  28 
  29 static inline struct inode_hash_entry * const hash(dev_t dev, int i)
  30 {
  31         return hash_table + hashfn(dev, i);
  32 }
  33 
  34 static void insert_inode_free(struct inode *inode)
     /*  */
  35 {
  36         inode->i_next = first_inode;
  37         inode->i_prev = first_inode->i_prev;
  38         inode->i_next->i_prev = inode;
  39         inode->i_prev->i_next = inode;
  40         first_inode = inode;
  41 }
  42 
  43 static void remove_inode_free(struct inode *inode)
     /*  */
  44 {
  45         if (first_inode == inode)
  46                 first_inode = first_inode->i_next;
  47         if (inode->i_next)
  48                 inode->i_next->i_prev = inode->i_prev;
  49         if (inode->i_prev)
  50                 inode->i_prev->i_next = inode->i_next;
  51         inode->i_next = inode->i_prev = NULL;
  52 }
  53 
  54 void insert_inode_hash(struct inode *inode)
     /*  */
  55 {
  56         struct inode_hash_entry *h;
  57         h = hash(inode->i_dev, inode->i_ino);
  58 
  59         inode->i_hash_next = h->inode;
  60         inode->i_hash_prev = NULL;
  61         if (inode->i_hash_next)
  62                 inode->i_hash_next->i_hash_prev = inode;
  63         h->inode = inode;
  64 }
  65 
  66 static void remove_inode_hash(struct inode *inode)
     /*  */
  67 {
  68         struct inode_hash_entry *h;
  69         h = hash(inode->i_dev, inode->i_ino);
  70 
  71         if (h->inode == inode)
  72                 h->inode = inode->i_hash_next;
  73         if (inode->i_hash_next)
  74                 inode->i_hash_next->i_hash_prev = inode->i_hash_prev;
  75         if (inode->i_hash_prev)
  76                 inode->i_hash_prev->i_hash_next = inode->i_hash_next;
  77         inode->i_hash_prev = inode->i_hash_next = NULL;
  78 }
  79 
  80 static void put_last_free(struct inode *inode)
     /*  */
  81 {
  82         remove_inode_free(inode);
  83         inode->i_prev = first_inode->i_prev;
  84         inode->i_prev->i_next = inode;
  85         inode->i_next = first_inode;
  86         inode->i_next->i_prev = inode;
  87 }
  88 
  89 void grow_inodes(void)
     /*  */
  90 {
  91         struct inode * inode;
  92         int i;
  93 
  94         if (!(inode = (struct inode*) get_free_page(GFP_KERNEL)))
  95                 return;
  96 
  97         i=PAGE_SIZE / sizeof(struct inode);
  98         nr_inodes += i;
  99         nr_free_inodes += i;
 100 
 101         if (!first_inode)
 102                 inode->i_next = inode->i_prev = first_inode = inode++, i--;
 103 
 104         for ( ; i ; i-- )
 105                 insert_inode_free(inode++);
 106 }
 107 
 108 unsigned long inode_init(unsigned long start, unsigned long end)
     /*  */
 109 {
 110         memset(hash_table, 0, sizeof(hash_table));
 111         first_inode = NULL;
 112         return start;
 113 }
 114 
 115 static void __wait_on_inode(struct inode *);
 116 
 117 static inline void wait_on_inode(struct inode * inode)
     /*  */
 118 {
 119         if (inode->i_lock)
 120                 __wait_on_inode(inode);
 121 }
 122 
 123 static inline void lock_inode(struct inode * inode)
     /*  */
 124 {
 125         wait_on_inode(inode);
 126         inode->i_lock = 1;
 127 }
 128 
 129 static inline void unlock_inode(struct inode * inode)
     /*  */
 130 {
 131         inode->i_lock = 0;
 132         wake_up(&inode->i_wait);
 133 }
 134 
 135 /*
 136  * Note that we don't want to disturb any wait-queues when we discard
 137  * an inode.
 138  *
 139  * Argghh. Got bitten by a gcc problem with inlining: no way to tell
 140  * the compiler that the inline asm function 'memset' changes 'inode'.
 141  * I've been searching for the bug for days, and was getting desperate.
 142  * Finally looked at the assembler output... Grrr.
 143  *
 144  * The solution is the weird use of 'volatile'. Ho humm. Have to report
 145  * it to the gcc lists, and hope we can do this more cleanly some day..
 146  */
 147 void clear_inode(struct inode * inode)
     /*  */
 148 {
 149         struct wait_queue * wait;
 150 
 151         wait_on_inode(inode);
 152         remove_inode_hash(inode);
 153         remove_inode_free(inode);
 154         wait = ((volatile struct inode *) inode)->i_wait;
 155         if (inode->i_count)
 156                 nr_free_inodes++;
 157         memset(inode,0,sizeof(*inode));
 158         ((volatile struct inode *) inode)->i_wait = wait;
 159         insert_inode_free(inode);
 160 }
 161 
 162 int fs_may_mount(dev_t dev)
     /*  */
 163 {
 164         struct inode * inode, * next;
 165         int i;
 166 
 167         next = first_inode;
 168         for (i = nr_inodes ; i > 0 ; i--) {
 169                 inode = next;
 170                 next = inode->i_next;   /* clear_inode() changes the queues.. */
 171                 if (inode->i_dev != dev)
 172                         continue;
 173                 if (inode->i_count || inode->i_dirt || inode->i_lock)
 174                         return 0;
 175                 clear_inode(inode);
 176         }
 177         return 1;
 178 }
 179 
 180 int fs_may_umount(dev_t dev, struct inode * mount_root)
     /*  */
 181 {
 182         struct inode * inode;
 183         int i;
 184 
 185         inode = first_inode;
 186         for (i=0 ; i < nr_inodes ; i++, inode = inode->i_next) {
 187                 if (inode->i_dev != dev || !inode->i_count)
 188                         continue;
 189                 if (inode == mount_root && inode->i_count == 1)
 190                         continue;
 191                 return 0;
 192         }
 193         return 1;
 194 }
 195 
 196 int fs_may_remount_ro(dev_t dev)
     /*  */
 197 {
 198         struct file * file;
 199         int i;
 200 
 201         /* Check that no files are currently opened for writing. */
 202         for (file = first_file, i=0; i<nr_files; i++, file=file->f_next) {
 203                 if (!file->f_count || !file->f_inode ||
 204                     file->f_inode->i_dev != dev)
 205                         continue;
 206                 if (S_ISREG(file->f_inode->i_mode) && (file->f_mode & 2))
 207                         return 0;
 208         }
 209         return 1;
 210 }
 211 
 212 static void write_inode(struct inode * inode)
     /*  */
 213 {
 214         if (!inode->i_dirt)
 215                 return;
 216         wait_on_inode(inode);
 217         if (!inode->i_dirt)
 218                 return;
 219         if (!inode->i_sb || !inode->i_sb->s_op || !inode->i_sb->s_op->write_inode) {
 220                 inode->i_dirt = 0;
 221                 return;
 222         }
 223         inode->i_lock = 1;      
 224         inode->i_sb->s_op->write_inode(inode);
 225         unlock_inode(inode);
 226 }
 227 
 228 static void read_inode(struct inode * inode)
     /*  */
 229 {
 230         lock_inode(inode);
 231         if (inode->i_sb && inode->i_sb->s_op && inode->i_sb->s_op->read_inode)
 232                 inode->i_sb->s_op->read_inode(inode);
 233         unlock_inode(inode);
 234 }
 235 
 236 /*
 237  * notify_change is called for inode-changing operations such as
 238  * chown, chmod, utime, and truncate.  It is guaranteed (unlike
 239  * write_inode) to be called from the context of the user requesting
 240  * the change.  It is not called for ordinary access-time updates.
 241  * NFS uses this to get the authentication correct.  -- jrs
 242  */
 243 
 244 int notify_change(int flags, struct inode * inode)
     /*  */
 245 {
 246         if (inode->i_sb && inode->i_sb->s_op  &&
 247             inode->i_sb->s_op->notify_change)
 248                 return inode->i_sb->s_op->notify_change(flags, inode);
 249         return 0;
 250 }
 251 
 252 /*
 253  * bmap is needed for demand-loading and paging: if this function
 254  * doesn't exist for a filesystem, then those things are impossible:
 255  * executables cannot be run from the filesystem etc...
 256  *
 257  * This isn't as bad as it sounds: the read-routines might still work,
 258  * so the filesystem would be otherwise ok (for example, you might have
 259  * a DOS filesystem, which doesn't lend itself to bmap very well, but
 260  * you could still transfer files to/from the filesystem)
 261  */
 262 int bmap(struct inode * inode, int block)
     /*  */
 263 {
 264         if (inode->i_op && inode->i_op->bmap)
 265                 return inode->i_op->bmap(inode,block);
 266         return 0;
 267 }
 268 
 269 void invalidate_inodes(dev_t dev)
     /*  */
 270 {
 271         struct inode * inode, * next;
 272         int i;
 273 
 274         next = first_inode;
 275         for(i = nr_inodes ; i > 0 ; i--) {
 276                 inode = next;
 277                 next = inode->i_next;           /* clear_inode() changes the queues.. */
 278                 if (inode->i_dev != dev)
 279                         continue;
 280                 if (inode->i_count || inode->i_dirt || inode->i_lock) {
 281                         printk("VFS: inode busy on removed device %d/%d\n", MAJOR(dev), MINOR(dev));
 282                         continue;
 283                 }
 284                 clear_inode(inode);
 285         }
 286 }
 287 
 288 void sync_inodes(dev_t dev)
     /*  */
 289 {
 290         int i;
 291         struct inode * inode;
 292 
 293         inode = first_inode;
 294         for(i = 0; i < nr_inodes*2; i++, inode = inode->i_next) {
 295                 if (dev && inode->i_dev != dev)
 296                         continue;
 297                 wait_on_inode(inode);
 298                 if (inode->i_dirt)
 299                         write_inode(inode);
 300         }
 301 }
 302 
 303 void iput(struct inode * inode)
     /*  */
 304 {
 305         if (!inode)
 306                 return;
 307         wait_on_inode(inode);
 308         if (!inode->i_count) {
 309                 printk("VFS: iput: trying to free free inode\n");
 310                 printk("VFS: device %d/%d, inode %lu, mode=0%07o\n",
 311                         MAJOR(inode->i_rdev), MINOR(inode->i_rdev),
 312                                         inode->i_ino, inode->i_mode);
 313                 return;
 314         }
 315         if (inode->i_pipe)
 316                 wake_up_interruptible(&PIPE_WAIT(*inode));
 317 repeat:
 318         if (inode->i_count>1) {
 319                 inode->i_count--;
 320                 return;
 321         }
 322         wake_up(&inode_wait);
 323         if (inode->i_pipe) {
 324                 unsigned long page = (unsigned long) PIPE_BASE(*inode);
 325                 PIPE_BASE(*inode) = NULL;
 326                 free_page(page);
 327         }
 328         if (inode->i_sb && inode->i_sb->s_op && inode->i_sb->s_op->put_inode) {
 329                 inode->i_sb->s_op->put_inode(inode);
 330                 if (!inode->i_nlink)
 331                         return;
 332         }
 333         if (inode->i_dirt) {
 334                 write_inode(inode);     /* we can sleep - so do again */
 335                 wait_on_inode(inode);
 336                 goto repeat;
 337         }
 338         inode->i_count--;
 339         nr_free_inodes++;
 340         return;
 341 }
 342 
 343 struct inode * get_empty_inode(void)
     /*  */
 344 {
 345         struct inode * inode, * best;
 346         int i;
 347 
 348         if (nr_inodes < NR_INODE && nr_free_inodes < (nr_inodes >> 2))
 349                 grow_inodes();
 350 repeat:
 351         inode = first_inode;
 352         best = NULL;
 353         for (i = 0; i<nr_inodes; inode = inode->i_next, i++) {
 354                 if (!inode->i_count) {
 355                         if (!best)
 356                                 best = inode;
 357                         if (!inode->i_dirt && !inode->i_lock) {
 358                                 best = inode;
 359                                 break;
 360                         }
 361                 }
 362         }
 363         if (!best || best->i_dirt || best->i_lock)
 364                 if (nr_inodes < NR_INODE) {
 365                         grow_inodes();
 366                         goto repeat;
 367                 }
 368         inode = best;
 369         if (!inode) {
 370                 printk("VFS: No free inodes - contact Linus\n");
 371                 sleep_on(&inode_wait);
 372                 goto repeat;
 373         }
 374         if (inode->i_lock) {
 375                 wait_on_inode(inode);
 376                 goto repeat;
 377         }
 378         if (inode->i_dirt) {
 379                 write_inode(inode);
 380                 goto repeat;
 381         }
 382         if (inode->i_count)
 383                 goto repeat;
 384         clear_inode(inode);
 385         inode->i_count = 1;
 386         inode->i_nlink = 1;
 387         inode->i_sem.count = 1;
 388         nr_free_inodes--;
 389         if (nr_free_inodes < 0) {
 390                 printk ("VFS: get_empty_inode: bad free inode count.\n");
 391                 nr_free_inodes = 0;
 392         }
 393         return inode;
 394 }
 395 
 396 struct inode * get_pipe_inode(void)
     /*  */
 397 {
 398         struct inode * inode;
 399         extern struct inode_operations pipe_inode_operations;
 400 
 401         if (!(inode = get_empty_inode()))
 402                 return NULL;
 403         if (!(PIPE_BASE(*inode) = (char*) __get_free_page(GFP_USER))) {
 404                 iput(inode);
 405                 return NULL;
 406         }
 407         inode->i_op = &pipe_inode_operations;
 408         inode->i_count = 2;     /* sum of readers/writers */
 409         PIPE_WAIT(*inode) = NULL;
 410         PIPE_START(*inode) = PIPE_LEN(*inode) = 0;
 411         PIPE_RD_OPENERS(*inode) = PIPE_WR_OPENERS(*inode) = 0;
 412         PIPE_READERS(*inode) = PIPE_WRITERS(*inode) = 1;
 413         PIPE_LOCK(*inode) = 0;
 414         inode->i_pipe = 1;
 415         inode->i_mode |= S_IFIFO | S_IRUSR | S_IWUSR;
 416         inode->i_uid = current->euid;
 417         inode->i_gid = current->egid;
 418         inode->i_atime = inode->i_mtime = inode->i_ctime = CURRENT_TIME;
 419         return inode;
 420 }
 421 
 422 struct inode * iget(struct super_block * sb,int nr)
     /*  */
 423 {
 424         return __iget(sb,nr,1);
 425 }
 426 
 427 struct inode * __iget(struct super_block * sb, int nr, int crossmntp)
     /*  */
 428 {
 429         static struct wait_queue * update_wait = NULL;
 430         struct inode_hash_entry * h;
 431         struct inode * inode;
 432         struct inode * empty = NULL;
 433 
 434         if (!sb)
 435                 panic("VFS: iget with sb==NULL");
 436         h = hash(sb->s_dev, nr);
 437 repeat:
 438         for (inode = h->inode; inode ; inode = inode->i_hash_next)
 439                 if (inode->i_dev == sb->s_dev && inode->i_ino == nr)
 440                         goto found_it;
 441         if (!empty) {
 442                 h->updating++;
 443                 empty = get_empty_inode();
 444                 if (!--h->updating)
 445                         wake_up(&update_wait);
 446                 if (empty)
 447                         goto repeat;
 448                 return (NULL);
 449         }
 450         inode = empty;
 451         inode->i_sb = sb;
 452         inode->i_dev = sb->s_dev;
 453         inode->i_ino = nr;
 454         inode->i_flags = sb->s_flags;
 455         put_last_free(inode);
 456         insert_inode_hash(inode);
 457         read_inode(inode);
 458         goto return_it;
 459 
 460 found_it:
 461         if (!inode->i_count)
 462                 nr_free_inodes--;
 463         inode->i_count++;
 464         wait_on_inode(inode);
 465         if (inode->i_dev != sb->s_dev || inode->i_ino != nr) {
 466                 printk("Whee.. inode changed from under us. Tell Linus\n");
 467                 iput(inode);
 468                 goto repeat;
 469         }
 470         if (crossmntp && inode->i_mount) {
 471                 struct inode * tmp = inode->i_mount;
 472                 tmp->i_count++;
 473                 iput(inode);
 474                 inode = tmp;
 475                 wait_on_inode(inode);
 476         }
 477         if (empty)
 478                 iput(empty);
 479 
 480 return_it:
 481         while (h->updating)
 482                 sleep_on(&update_wait);
 483         return inode;
 484 }
 485 
 486 /*
 487  * The "new" scheduling primitives (new as of 0.97 or so) allow this to
 488  * be done without disabling interrupts (other than in the actual queue
 489  * updating things: only a couple of 386 instructions). This should be
 490  * much better for interrupt latency.
 491  */
 492 static void __wait_on_inode(struct inode * inode)
     /*  */
 493 {
 494         struct wait_queue wait = { current, NULL };
 495 
 496         add_wait_queue(&inode->i_wait, &wait);
 497 repeat:
 498         current->state = TASK_UNINTERRUPTIBLE;
 499         if (inode->i_lock) {
 500                 schedule();
 501                 goto repeat;
 502         }
 503         remove_wait_queue(&inode->i_wait, &wait);
 504         current->state = TASK_RUNNING;
 505 }

/* */