summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--ufs/inode.c510
1 files changed, 510 insertions, 0 deletions
diff --git a/ufs/inode.c b/ufs/inode.c
new file mode 100644
index 00000000..113f42d9
--- /dev/null
+++ b/ufs/inode.c
@@ -0,0 +1,510 @@
+/* Inode management routines
+ Copyright (C) 1994 Free Software Foundation
+
+ This program is free software; you can redistribute it and/or
+ modify it under the terms of the GNU General Public License as
+ published by the Free Software Foundation; either version 2, or (at
+ your option) any later version.
+
+ This program is distributed in the hope that it will be useful, but
+ WITHOUT ANY WARRANTY; without even the implied warranty of
+ MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ General Public License for more details.
+
+ You should have received a copy of the GNU General Public License
+ along with this program; if not, write to the Free Software
+ Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA. */
+
+#include "ufs.h"
+#include "dinode.h"
+#include "fs.h"
+#include <string.h>
+
+#define INOHSZ 512
+#if ((INOHSZ&(INOHSZ-1)) == 0)
+#define INOHASH(ino) ((ino)&(INOHSZ-1))
+#else
+#define INOHASH(ino) (((unsigned)(ino))%INOHSZ)
+#endif
+
+static struct node *nodehash[INOHSZ];
+static error_t read_disknode (struct node *np);
+
+spin_lock_t gennumberlock = SPIN_LOCK_INITIALIZER;
+
+/* Initialize the inode hash table. */
+void
+inode_init ()
+{
+ int n;
+ for (n = 0; n < INOHSZ; n++)
+ nodehash[n] = 0;
+ mutex_init (&dinmaplock);
+ mutex_init (&sinmaplock);
+}
+
+/* Fetch inode INUM, set *NPP to the node structure;
+ gain one user reference and lock the node. */
+error_t
+iget (ino_t inum, struct node **npp)
+{
+ struct disknode *dn;
+ struct node *np;
+ error_t err;
+
+ spin_lock (&diskfs_node_refcnt_lock);
+ for (np = nodehash[INOHASH(inum)]; np; np = np->dn->hnext)
+ {
+ if (np->dn->number != inum)
+ continue;
+
+ np->references++;
+ spin_unlock (&diskfs_node_refcnt_lock);
+ mutex_lock (&np->lock);
+ *npp = np;
+ return 0;
+ }
+
+ dn = malloc (sizeof (struct disknode));
+
+ dn->number = inum;
+ dn->dirents = 0;
+
+ mutex_init (&dn->rwlock_master);
+ condition_init (&dn->rwlock_wakeup);
+ rwlock_init (&dn->dinlock);
+ rwlock_init (&dn->sinlock);
+ rwlock_init (&dn->datalock);
+ dn->dinloc = 0;
+ dn->sinloc = 0;
+ dn->sininfo = 0;
+ dn->fileinfo = 0;
+
+ np = diskfs_make_node (dn);
+ mutex_lock (&np->lock);
+ dn->hnext = nodehash[INOHASH(inum)];
+ if (dn->hnext)
+ dn->hnext->dn->hprevp = &dn->hnext;
+ dn->hprevp = &nodehash[INOHASH(inum)];
+ nodehash[INOHASH(inum)] = np;
+ spin_unlock (&diskfs_node_refcnt_lock);
+
+ err = read_disknode (np);
+ if (lblkno (sblock, np->dn_stat.st_size) < NDADDR)
+ np->allocsize = fragroundup (sblock, np->dn_stat.st_size);
+ else
+ np->allocsize = blkroundup (sblock, np->dn_stat.st_size);
+
+ /* XXX */
+ assert (np->allocsize || !dinodes[np->dn->number].di_db[0]);
+
+ if (!diskfs_readonly && !np->dn_stat.st_gen)
+ {
+ spin_lock (&gennumberlock);
+ if (++nextgennumber < diskfs_mtime->seconds)
+ nextgennumber = diskfs_mtime->seconds;
+ np->dn_stat.st_gen = nextgennumber;
+ spin_unlock (&gennumberlock);
+ np->dn_set_ctime = 1;
+ }
+
+ if (err)
+ return err;
+ else
+ {
+ *npp = np;
+ return 0;
+ }
+}
+
+/* Lookup node INUM (which must have a reference already) and return it
+ without allocating any new references. */
+struct node *
+ifind (ino_t inum)
+{
+ struct node *np;
+
+ spin_lock (&diskfs_node_refcnt_lock);
+ for (np = nodehash[INOHASH(inum)]; np; np = np->dn->hnext)
+ {
+ if (np->dn->number != inum)
+ continue;
+
+ assert (np->references);
+ spin_unlock (&diskfs_node_refcnt_lock);
+ return np;
+ }
+ assert (0);
+}
+
+/* The last reference to a node has gone away; drop
+ it from the hash table and clean all state in the dn structure. */
+void
+diskfs_node_norefs (struct node *np)
+{
+ *np->dn->hprevp = np->dn->hnext;
+ if (np->dn->hnext)
+ np->dn->hnext->dn->hprevp = np->dn->hprevp;
+ if (np->dn->dirents)
+ free (np->dn->dirents);
+ assert (!np->dn->sininfo && !np->dn->fileinfo);
+ assert (!np->dn->dinloc && !np->dn->sinloc);
+ free (np->dn);
+ free (np);
+}
+
+/* The last hard referencs to a node has gone away; arrange to have
+ all the weak references dropped that can be. */
+void
+diskfs_lost_hardrefs (struct node *np)
+{
+ drop_pager_softrefs (np);
+}
+
+/* A new hard reference to a node has been created; it's now OK to
+ have unused weak references. */
+void
+diskfs_new_hardrefs (struct node *np)
+{
+ allow_pager_softrefs (np);
+}
+
+/* Read stat information out of the dinode. */
+static error_t
+read_disknode (struct node *np)
+{
+ struct stat *st = &np->dn_stat;
+ struct dinode *di = &dinodes[np->dn->number];
+ error_t err;
+
+ err = diskfs_catch_exception ();
+ if (err)
+ return err;
+
+ st->st_fstype = FSTYPE_UFS;
+ st->st_fsid = 0; /* XXX should fill this */
+ st->st_ino = np->dn->number;
+ st->st_gen = di->di_gen;
+ st->st_rdev = di->di_rdev;
+ st->st_mode = di->di_model | (di->di_modeh << 16);
+ st->st_nlink = di->di_nlink;
+ st->st_size = di->di_size;
+#ifdef notyet
+ st->st_atimespec = di->di_atime;
+ st->st_mtimespec = di->di_mtime;
+ st->st_ctimespec = di->di_ctime;
+#else
+ st->st_atime = di->di_atime.ts_sec;
+ st->st_atime_usec = di->di_atime.ts_nsec / 1000;
+ st->st_mtime = di->di_mtime.ts_sec;
+ st->st_mtime_usec = di->di_mtime.ts_nsec / 1000;
+ st->st_ctime = di->di_ctime.ts_sec;
+ st->st_ctime_usec = di->di_ctime.ts_nsec / 1000;
+#endif
+ st->st_blksize = sblock->fs_bsize;
+ st->st_blocks = di->di_blocks;
+ st->st_flags = di->di_flags;
+
+ if (sblock->fs_inodefmt < FS_44INODEFMT)
+ {
+ st->st_uid = di->di_ouid;
+ st->st_gid = di->di_ogid;
+ st->st_author = 0;
+ }
+ else
+ {
+ st->st_uid = di->di_uid;
+ st->st_gid = di->di_gid;
+ st->st_author = di->di_author;
+ if (st->st_author == -1)
+ st->st_author = st->st_uid;
+ }
+
+ diskfs_end_catch_exception ();
+ if (!S_ISBLK (st->st_mode) && !S_ISCHR (st->st_mode))
+ st->st_rdev = 0;
+ return 0;
+}
+
+static void
+write_node (struct node *np)
+{
+ struct stat *st = &np->dn_stat;
+ struct dinode *di = &dinodes[np->dn->number];
+ error_t err;
+
+ assert (!np->dn_set_ctime && !np->dn_set_atime && !np->dn_set_mtime);
+ if (np->dn_stat_dirty)
+ {
+ assert (!diskfs_readonly);
+
+ err = diskfs_catch_exception ();
+ if (err)
+ return;
+
+ di->di_gen = st->st_gen;
+
+ if (S_ISBLK (st->st_mode) || S_ISCHR (st->st_mode))
+ di->di_rdev = st->st_rdev;
+
+ /* We happen to know that the stat mode bits are the same
+ as the ufs mode bits. */
+
+ if (compat_mode == COMPAT_GNU)
+ {
+ di->di_model = st->st_mode & 0xffff;
+ di->di_modeh = (st->st_mode >> 16) & 0xffff;
+ }
+ else
+ {
+ di->di_model = st->st_mode & 0xffff;
+ di->di_modeh = 0;
+ }
+
+ if (compat_mode != COMPAT_BSD42)
+ {
+ di->di_uid = st->st_uid;
+ di->di_gid = st->st_gid;
+ }
+
+ if (sblock->fs_inodefmt < FS_44INODEFMT)
+ {
+ di->di_ouid = st->st_uid & 0xffff;
+ di->di_ogid = st->st_gid & 0xffff;
+ }
+ else if (compat_mode == COMPAT_GNU)
+ di->di_author = st->st_author;
+
+ di->di_nlink = st->st_nlink;
+ di->di_size = st->st_size;
+#ifdef notyet
+ di->di_atime = st->st_atimespec;
+ di->di_mtime = st->st_mtimespec;
+ di->di_ctime = st->st_ctimespec;
+#else
+ di->di_atime.ts_sec = st->st_atime;
+ di->di_atime.ts_nsec = st->st_atime_usec * 1000;
+ di->di_mtime.ts_sec = st->st_mtime;
+ di->di_mtime.ts_nsec = st->st_mtime_usec * 1000;
+ di->di_ctime.ts_sec = st->st_ctime;
+ di->di_ctime.ts_nsec = st->st_ctime_usec * 1000;
+#endif
+ di->di_blocks = st->st_blocks;
+ di->di_flags = st->st_flags;
+
+ diskfs_end_catch_exception ();
+ np->dn_stat_dirty = 0;
+ }
+}
+
+/* See if we should create a symlink by writing it directly into
+ the block pointer array. Returning EINVAL tells diskfs to do it
+ the usual way. */
+static error_t
+create_symlink_hook (struct node *np, char *target)
+{
+ int len = strlen (target);
+ error_t err;
+
+ if (!direct_symlink_extension)
+ return EINVAL;
+
+ assert (!COMPAT_BSD42);
+
+ if (len >= sblock->fs_maxsymlinklen)
+ return EINVAL;
+
+ err = diskfs_catch_exception ();
+ if (err)
+ return err;
+
+ bcopy (target, dinodes[np->dn->number].di_shortlink, len);
+ np->dn_stat.st_size = len;
+ np->dn_set_ctime = 1;
+ np->dn_set_mtime = 1;
+
+ diskfs_end_catch_exception ();
+ return 0;
+}
+error_t (*diskfs_create_symlink_hook)(struct node *, char *)
+ = create_symlink_hook;
+
+/* Check if this symlink is stored directly in the block pointer array.
+ Returning EINVAL tells diskfs to do it the usual way. */
+static error_t
+read_symlink_hook (struct node *np,
+ char *buf)
+{
+ error_t err;
+
+ if (!direct_symlink_extension
+ || np->dn_stat.st_size >= sblock->fs_maxsymlinklen)
+ return EINVAL;
+
+ err = diskfs_catch_exception ();
+ if (err)
+ return err;
+
+ bcopy (dinodes[np->dn->number].di_shortlink, buf, np->dn_stat.st_size);
+ np->dn_set_atime = 1;
+
+ diskfs_end_catch_exception ();
+ return 0;
+}
+error_t (*diskfs_read_symlink_hook)(struct node *, char *)
+ = read_symlink_hook;
+
+
+/* Write all active disknodes into the dinode pager. */
+void
+write_all_disknodes ()
+{
+ int n;
+ struct node *np;
+
+ spin_lock (&diskfs_node_refcnt_lock);
+ for (n = 0; n < INOHSZ; n++)
+ for (np = nodehash[n]; np; np = np->dn->hnext)
+ {
+ diskfs_set_node_times (np);
+ write_node (np);
+ }
+ spin_unlock (&diskfs_node_refcnt_lock);
+}
+
+void
+diskfs_write_disknode (struct node *np, int wait)
+{
+ write_node (np);
+ sync_dinode (np, wait);
+}
+
+
+/* Implement the diskfs_set_statfs callback from the diskfs library;
+ see <hurd/diskfs.h> for the interface description. */
+error_t
+diskfs_set_statfs (struct fsys_statfsbuf *st)
+{
+ st->fsys_stb_type = FSTYPE_UFS;
+ st->fsys_stb_bsize = sblock->fs_bsize;
+ st->fsys_stb_fsize = sblock->fs_fsize;
+ st->fsys_stb_blocks = sblock->fs_dsize;
+ st->fsys_stb_bfree = (sblock->fs_cstotal.cs_nbfree * sblock->fs_frag
+ + sblock->fs_cstotal.cs_nffree);
+ st->fsys_stb_bavail = ((sblock->fs_dsize * (100 - sblock->fs_minfree) / 100)
+ - (sblock->fs_dsize - st->fsys_stb_bfree));
+ st->fsys_stb_files = sblock->fs_ncg * sblock->fs_ipg - 2; /* not 0 or 1 */
+ st->fsys_stb_ffree = sblock->fs_cstotal.cs_nifree;
+ st->fsys_stb_fsid = 0;
+ return 0;
+}
+
+/* Implement the diskfs_set_translator callback from the diskfs
+ library; see <hurd/diskfs.h> for the interface description. */
+error_t
+diskfs_set_translator (struct node *np, char *name, u_int namelen,
+ struct protid *cred)
+{
+ daddr_t blkno;
+ error_t err;
+ char buf[sblock->fs_bsize];
+
+ if (compat_mode != COMPAT_GNU)
+ return EOPNOTSUPP;
+
+ if (namelen + sizeof (u_int) > sblock->fs_bsize)
+ return ENAMETOOLONG;
+
+ err = diskfs_catch_exception ();
+ if (err)
+ return err;
+
+ blkno = dinodes[np->dn->number].di_trans;
+
+ if (namelen && !blkno)
+ {
+ /* Allocate block for translator */
+ err = ffs_alloc (np, 0, 0, sblock->fs_bsize, &blkno, cred);
+ if (err)
+ {
+ diskfs_end_catch_exception ();
+ return err;
+ }
+ dinodes[np->dn->number].di_trans = blkno;
+ np->dn_set_ctime = 1;
+ }
+ else if (!namelen && blkno)
+ {
+ /* Clear block for translator going away. */
+ ffs_blkfree (np, blkno, sblock->fs_bsize);
+ dinodes[np->dn->number].di_trans = 0;
+ np->dn_set_ctime = 1;
+ }
+
+ diskfs_end_catch_exception ();
+
+ if (namelen)
+ {
+ bcopy (&namelen, buf, sizeof (u_int));
+ bcopy (name, buf + sizeof (u_int), namelen);
+ err = dev_write_sync (fsbtodb (sblock, blkno),
+ (vm_address_t)buf, sblock->fs_bsize);
+ np->dn_set_ctime = 1;
+ }
+ return err;
+}
+
+/* Implement the diskfs_get_translator callback from the diskfs library.
+ See <hurd/diskfs.h> for the interface description. */
+error_t
+diskfs_get_translator (struct node *np, char **namep, u_int *namelen)
+{
+ error_t err;
+ daddr_t blkno;
+ char *buf;
+ u_int datalen;
+
+ err = diskfs_catch_exception ();
+ if (err)
+ return err;
+ blkno = dinodes[np->dn->number].di_trans;
+ diskfs_end_catch_exception ();
+
+ assert (blkno);
+
+ err = dev_read_sync (fsbtodb (sblock, blkno), (vm_address_t *)&buf,
+ sblock->fs_bsize);
+ if (err)
+ return err;
+
+ datalen = *(u_int *)buf;
+ if (datalen > *namelen)
+ vm_allocate (mach_task_self (), (vm_address_t *) namep, datalen, 1);
+ bcopy (buf + sizeof (u_int), *namep, datalen);
+ *namelen = datalen;
+ return 0;
+}
+
+/* Implement the diskfs_node_translated callback from the diskfs library.
+ See <hurd/diskfs.h> for the interface description. */
+int
+diskfs_node_translated (struct node *np)
+{
+ int ret;
+
+ if (diskfs_catch_exception ())
+ return 0;
+
+ ret = !! dinodes[np->dn->number].di_trans;
+ diskfs_end_catch_exception ();
+ return ret;
+}
+
+/* Called when all hard ports have gone away. */
+void
+diskfs_shutdown_soft_ports ()
+{
+ /* Should initiate termination of internally held pager ports
+ (the only things that should be soft) XXX */
+}
+