reenable use of direct IO now that DIOCINFO and O_DIRECT are working.

[thirdparty/xfsprogs-dev.git] / libxfs / init.c

/*
 * Copyright (c) 2000 Silicon Graphics, Inc.  All Rights Reserved.
 *
 * This program is free software; you can redistribute it and/or modify it
 * under the terms of version 2 of the GNU General Public License as
 * published by the Free Software Foundation.
 *
 * This program is distributed in the hope that it would be useful, but
 * WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.
 *
 * Further, this software is distributed without any warranty that it is
 * free of the rightful claim of any third person regarding infringement
 * or the like.  Any license provided herein, whether implied or
 * otherwise, applies only to this software file.  Patent licenses, if
 * any, provided herein do not apply to combinations of this program with
 * other software, or any other product whatsoever.
 *
 * You should have received a copy of the GNU General Public License along
 * with this program; if not, write the Free Software Foundation, Inc., 59
 * Temple Place - Suite 330, Boston MA 02111-1307, USA.
 *
 * Contact information: Silicon Graphics, Inc., 1600 Amphitheatre Pkwy,
 * Mountain View, CA  94043, or:
 *
 * http://www.sgi.com
 *
 * For further information regarding this notice, see:
 *
 * http://oss.sgi.com/projects/GenInfo/SGIGPLNoticeExplan/
 */

#define ustat __kernel_ustat
#include <libxfs.h>
#include <fcntl.h>
#include <errno.h>
#include <mntent.h>
#include <sys/stat.h>
#undef ustat
#include <sys/ustat.h>
#include <sys/ioctl.h>
#include <sys/mount.h>

#ifndef BLKSETSIZE	/* Baaad m'kay, but it's not in libc yet */
#define BLKSETSIZE _IO(0x12,108)	/* set device block size */
#endif

#define findrawpath(x)	x
#define findblockpath(x) x

char *progname = "libxfs";	/* default, changed by each tool */

/*
 * dev_map - map open devices to fd.
 */
#define MAX_DEVS 10	/* arbitary maximum */
int nextfakedev = -1;	/* device number to give to next fake device */
static struct dev_to_fd {
	dev_t dev;
	int fd;
} dev_map[MAX_DEVS]={{0}};

static int
check_ismounted(char *name, char *block, int verbose)
{
	struct ustat	ust;
	struct stat64	st;

	if (stat64(block, &st) < 0)
		return 0;
	if ((st.st_mode & S_IFMT) != S_IFBLK)
		return 0;
	if (ustat(st.st_rdev, &ust) >= 0) {
		if (verbose)
			fprintf(stderr,
				"%s: %s contains a mounted filesystem\n",
				progname, name);
		return 1;
	}
	return 0;
}

/*
 * Checks whether a given device has a mounted, writable
 * filesystem, returns 1 if it does & fatal (just warns
 * if not fatal, but allows us to proceed).
 * 
 * Useful to tools which will produce uncertain results
 * if the filesystem is active - repair, check, logprint.
 */
static int
check_isactive(char *name, char *block, int fatal)
{
	int		sts = 0;
	FILE		*f;
	struct mntent	*mnt;

	if (check_ismounted(name, block, 0)) {
		if ((f = setmntent(MOUNTED, "r")) == NULL) {
			fprintf(stderr,
				"%s: %s contains a possibly writable, mounted "
				"filesystem\n", progname, name);
			return fatal;
		}
		while ((mnt = getmntent(f)) != NULL) {
			if (hasmntopt(mnt, MNTOPT_RO) != NULL)
				break;
		}
		if (mnt == NULL) {
			fprintf(stderr,
				"%s: %s contains a writable mounted "
				"filesystem\n", progname, name);
			sts = fatal;
		}
		endmntent(f);
	}
	return sts;
}

static __int64_t
findsize(char *path)
{
	int	fd;
	int	error;
	long	size;
	struct stat64   st;

	/* Test to see if we are dealing with a regular file rather than a
	 * block device, if we are just use the size returned by stat64
	 */
	if (stat64(path, &st) < 0) {
		fprintf(stderr, "%s: "
			"cannot stat the device special file \"%s\": %s\n",
			progname, path, strerror(errno));
		exit(1);
	}
	if ((st.st_mode & S_IFMT) == S_IFREG) {
		return (__int64_t)(st.st_size >> 9);
	}

	if ((fd = open(path, 0)) < 0) {
		fprintf(stderr, "%s: "
			"error opening the device special file \"%s\": %s\n",
			progname, path, strerror(errno));
		exit(1);
	}
	error = ioctl(fd, BLKGETSIZE, &size);
	if (error < 0) {
		fprintf(stderr, "%s: can't determine device size\n", progname);
		exit(1);
	}

	close(fd);

	return (__int64_t)size;
}


/* libxfs_device_to_fd: 
 *     lookup a device number in the device map
 *     return the associated fd
 */
int
libxfs_device_to_fd(dev_t device)
{
	int d;
	
	for (d=0;d<MAX_DEVS;d++)
		if (dev_map[d].dev == device) 
			return dev_map[d].fd;
	
	fprintf(stderr, "%s: device_to_fd: device %Ld is not open\n", 
		progname, device);
	exit(1);
}

/* libxfs_device_open:
 *     open a device and return its device number
 */
dev_t
libxfs_device_open(char *path, int creat, int readonly)
{
	int		fd;
	dev_t		dev;
	int		d;
	struct stat     statb;
	int		blocksize = 512; /* bytes */

	if ((fd = open(path,
			(readonly ? O_RDONLY : O_RDWR) |
			(creat ? O_CREAT|O_TRUNC : 0),
			0666)) < 0) {
		fprintf(stderr, "%s: cannot open %s: %s\n",
			progname, path, strerror(errno));
		exit(1);
	}

	if (stat(path, &statb)<0) {
		fprintf(stderr, "%s: cannot stat %s: %s\n",
			progname, path, strerror(errno));
		exit(1);
	}
	
	/* Set device blocksize to 512 bytes */
	if ((statb.st_mode & S_IFMT) == S_IFBLK) {
		if (ioctl(fd, BLKSETSIZE, &blocksize) < 0) {
			fprintf(stderr, "%s: warning - cannot set blocksize on "
				"block device %s: %s\n",
				progname, path, strerror(errno));
		}
	}

	/* get the device number from the stat buf - unless
	 * we're not opening a real device, in which case
	 * choose a new fake device number
	 */
	dev=(statb.st_rdev)?(statb.st_rdev):(nextfakedev--);

	for (d=0;d<MAX_DEVS;d++)
		if (dev_map[d].dev == dev) {
			fprintf(stderr, "%s: device %Ld is already open\n", 
			    progname, dev);
			exit(1);
		}

	for (d=0;d<MAX_DEVS;d++)
		if (!dev_map[d].dev) {
			dev_map[d].dev=dev;
			dev_map[d].fd=fd;
			
			return dev;
		}

	fprintf(stderr, "%s: device_open: too many open devices\n", progname);
	exit(1);
}

void
libxfs_device_close(dev_t dev)
{
	int     d;

	for (d=0;d<MAX_DEVS;d++)
		if (dev_map[d].dev == dev) {
			int fd;
			
			fd=dev_map[d].dev;
			dev_map[d].dev=dev_map[d].fd=0;
			
			fsync(fd);
			ioctl(fd, BLKFLSBUF, 0);
			close(fd);
			
			return;
		}

	fprintf(stderr, "%s: device_close: device %Ld is not open\n",
			progname, dev);
	ASSERT(0);
	exit(1);
}


/*
 * libxfs initialization.
 * Caller gets a 0 on failure (and we print a message), 1 on success.
 */
int
libxfs_init(libxfs_init_t *a)
{
	char		*blockfile;
	char		curdir[MAXPATHLEN];
	char		*dname;
	char		dpath[25];
	int		fd;
	char		*logname;
	char		logpath[25];
	int		needcd;
	char		*rawfile;
	char		*rtname;
	char		rtpath[25];
	int		rval = 0;
	int		readonly;
	int		inactive;
	struct stat64	stbuf;

	dpath[0] = logpath[0] = rtpath[0] = '\0';
	dname = a->dname;
	logname = a->logname;
	rtname = a->rtname;
	a->ddev = a->logdev = a->rtdev = 0;
	a->dfd = a->logfd = a->rtfd = -1;
	a->dsize = a->logBBsize = a->logBBstart = a->rtsize = 0;

	(void)getcwd(curdir,MAXPATHLEN);
	needcd = 0;
	fd = -1;
	readonly = (a->isreadonly & LIBXFS_ISREADONLY);
	inactive = (a->isreadonly & LIBXFS_ISINACTIVE);
	if (a->volname) {
		if (stat64(a->volname, &stbuf) < 0) {
			perror(a->volname);
			goto done;
		}
		if (!(rawfile = findrawpath(a->volname))) {
			fprintf(stderr, "%s: "
				"can't find a character device matching %s\n",
				progname, a->volname);
			goto done;
		}
		if (!(blockfile = findblockpath(a->volname))) {
			fprintf(stderr, "%s: "
				"can't find a block device matching %s\n",
				progname, a->volname);
			goto done;
		}
		if (!readonly && !inactive && check_ismounted(
					a->volname, blockfile, 1))
			goto done;
		if (inactive && check_isactive(
					a->volname, blockfile, readonly))
			goto done;
		needcd = 1;
		fd = open(rawfile, O_RDONLY);
#ifdef HAVE_VOLUME_MANAGER
		xlv_getdev_t getdev;
		if (ioctl(fd, DIOCGETVOLDEV, &getdev) < 0)
#else
		if (1)
#endif
		{
			if (a->notvolok) {
				dname = a->dname = a->volname;
				a->volname = NULL;
				goto voldone;
			}
			fprintf(stderr, "%s: "
				"%s is not a volume device name\n",
				progname, a->volname);
			if (a->notvolmsg)
				fprintf(stderr, a->notvolmsg, a->volname);
			goto done;
		}
#ifdef HAVE_VOLUME_MANAGER
		if (getdev.data_subvol_dev && dname) {
			fprintf(stderr, "%s: "
				"%s has a data subvolume, cannot specify %s\n",
				progname, a->volname, dname);
			goto done;
		}
		if (getdev.log_subvol_dev && logname) {
			fprintf(stderr, "%s: "
				"%s has a log subvolume, cannot specify %s\n",
				progname, a->volname, logname);
			goto done;
		}
		if (getdev.rt_subvol_dev && rtname) {
			fprintf(stderr, "%s: %s has a realtime subvolume, "
				"cannot specify %s\n",
				progname, a->volname, rtname);
			goto done;
		}
		if (!dname && getdev.data_subvol_dev) {
			strcpy(dpath, "/tmp/libxfsdXXXXXX");
			(void)mktemp(dpath);
			if (mknod(dpath, S_IFCHR | 0600,
				  getdev.data_subvol_dev) < 0) {
				fprintf(stderr, "%s: mknod failed: %s\n",
					progname, strerror(errno));
				goto done;
			}
			dname = dpath;
		}
		if (!logname && getdev.log_subvol_dev) {
			strcpy(logpath, "/tmp/libxfslXXXXXX");
			(void)mktemp(logpath);
			if (mknod(logpath, S_IFCHR | 0600,
				  getdev.log_subvol_dev) < 0) {
				fprintf(stderr, "%s: mknod failed: %s\n",
					progname, strerror(errno));
				goto done;
			}
			logname = logpath;
		}
		if (!rtname && getdev.rt_subvol_dev) {
			strcpy(rtpath, "/tmp/libxfsrXXXXXX");
			(void)mktemp(rtpath);
			if (mknod(rtpath, S_IFCHR | 0600,
				  getdev.rt_subvol_dev) < 0) {
				fprintf(stderr, "%s: mknod failed: %s\n",
					progname, strerror(errno));
				goto done;
			}
			rtname = rtpath;
		}
#endif
	}
voldone:
	if (dname) {
		if (dname[0] != '/' && needcd)
			chdir(curdir);
		if (a->disfile) {
			a->ddev= libxfs_device_open(dname, a->dcreat, readonly);
			a->dfd = libxfs_device_to_fd(a->ddev);
		} else {
			if (stat64(dname, &stbuf) < 0) {
				fprintf(stderr, "%s: stat64 failed on %s: %s\n",
					progname, dname, strerror(errno));
				goto done;
			}
			if (!(rawfile = findrawpath(dname))) {
				fprintf(stderr, "%s: can't find a char device "
					"matching %s\n", progname, dname);
				goto done;
			}
			if (!(blockfile = findblockpath(dname))) {
				fprintf(stderr, "%s: can't find a block device "
					"matching %s\n", progname, dname);
				goto done;
			}
			if (!readonly && !inactive && check_ismounted(
						dname, blockfile, 1))
				goto done;
			if (inactive && check_isactive(
						dname, blockfile, readonly))
				goto done;
			a->ddev = libxfs_device_open(rawfile,
					a->dcreat, readonly);
			a->dfd = libxfs_device_to_fd(a->ddev);
			a->dsize = findsize(rawfile);
		}
		needcd = 1;
	} else
		a->dsize = 0;
	if (logname) {
		if (logname[0] != '/' && needcd)
			chdir(curdir);
		if (a->lisfile) {
			a->logdev = libxfs_device_open(logname,
					a->lcreat, readonly);
			a->logfd = libxfs_device_to_fd(a->logdev);
		} else {
			if (stat64(logname, &stbuf) < 0) {
				fprintf(stderr, "%s: stat64 failed on %s: %s\n",
					progname, logname, strerror(errno));
				goto done;
			}
			if (!(rawfile = findrawpath(logname))) {
				fprintf(stderr, "%s: can't find a char device "
					"matching %s\n", progname, logname);
				goto done;
			}
			if (!(blockfile = findblockpath(logname))) {
				fprintf(stderr, "%s: can't find a block device "
					"matching %s\n", progname, logname);
				goto done;
			}
			if (!readonly && !inactive && check_ismounted(
						logname, blockfile, 1))
				goto done;
			else if (inactive && check_isactive(
						logname, blockfile, readonly))
				goto done;
			a->logdev = libxfs_device_open(rawfile,
					a->lcreat, readonly);
			a->logfd = libxfs_device_to_fd(a->logdev);
			a->logBBsize = findsize(rawfile);
		}
		needcd = 1;
	} else
		a->logBBsize = 0;
	if (rtname) {
		if (rtname[0] != '/' && needcd)
			chdir(curdir);
		if (a->risfile) {
			a->rtdev = libxfs_device_open(rtname,
					a->rcreat, readonly);
			a->rtfd = libxfs_device_to_fd(a->rtdev);
		} else {
			if (stat64(rtname, &stbuf) < 0) {
				fprintf(stderr, "%s: stat64 failed on %s: %s\n",
					progname, rtname, strerror(errno));
				goto done;
			}
			if (!(rawfile = findrawpath(rtname))) {
				fprintf(stderr, "%s: can't find a char device "
					"matching %s\n", progname, rtname);
				goto done;
			}
			if (!(blockfile = findblockpath(rtname))) {
				fprintf(stderr, "%s: can't find a block device "
					"matching %s\n", progname, rtname);
				goto done;
			}
			if (!readonly && !inactive && check_ismounted(
						rtname, blockfile, 1))
				goto done;
			if (inactive && check_isactive(
						rtname, blockfile, readonly))
				goto done;
			a->rtdev = libxfs_device_open(rawfile,
					a->rcreat, readonly);
			a->rtfd = libxfs_device_to_fd(a->rtdev);
			a->rtsize = findsize(rawfile);
		}
		needcd = 1;
	} else
		a->rtsize = 0;
	if (a->dsize < 0) {
		fprintf(stderr, "%s: can't get size for data subvolume\n",
			progname);
		goto done;
	}
	if (a->logBBsize < 0) {
		fprintf(stderr, "%s: can't get size for log subvolume\n",
			progname);
		goto done;
	}
	if (a->rtsize < 0) {
		fprintf(stderr, "%s: can't get size for realtime subvolume\n",
			progname);
		goto done;
	}
	if (needcd)
		chdir(curdir);
	rval = 1;
done:
	if (dpath[0])
		unlink(dpath);
	if (logpath[0])
		unlink(logpath);
	if (rtpath[0])
		unlink(rtpath);
	if (fd >= 0)
		close(fd);
	if (!rval && a->ddev)
		libxfs_device_close(a->ddev);
	if (!rval && a->logdev)
		libxfs_device_close(a->logdev);
	if (!rval && a->rtdev)
		libxfs_device_close(a->rtdev);
	return rval;
}


/*
 * Initialize/destroy all of the zone allocators we use.
 */
static void
manage_zones(int release)
{
	extern xfs_zone_t	*xfs_ili_zone;
	extern xfs_zone_t	*xfs_inode_zone;
	extern xfs_zone_t	*xfs_ifork_zone;
	extern xfs_zone_t	*xfs_dabuf_zone;
	extern xfs_zone_t	*xfs_buf_item_zone;
	extern xfs_zone_t	*xfs_da_state_zone;
	extern xfs_zone_t	*xfs_btree_cur_zone;
	extern xfs_zone_t	*xfs_bmap_free_item_zone;
	extern void		xfs_dir_startup();

	if (release) {	/* free zone allocation */
		libxfs_free(xfs_inode_zone);
		libxfs_free(xfs_ifork_zone);
		libxfs_free(xfs_dabuf_zone);
		libxfs_free(xfs_buf_item_zone);
		libxfs_free(xfs_da_state_zone);
		libxfs_free(xfs_btree_cur_zone);
		libxfs_free(xfs_bmap_free_item_zone);
		return;
	}
	/* otherwise initialise zone allocation */
	xfs_inode_zone = libxfs_zone_init(sizeof(xfs_inode_t), "xfs_inode");
	xfs_ifork_zone = libxfs_zone_init(sizeof(xfs_ifork_t), "xfs_ifork");
	xfs_dabuf_zone = libxfs_zone_init(sizeof(xfs_dabuf_t), "xfs_dabuf");
	xfs_ili_zone = libxfs_zone_init(
			sizeof(xfs_inode_log_item_t), "xfs_inode_log_item");
	xfs_buf_item_zone = libxfs_zone_init(
			sizeof(xfs_buf_log_item_t), "xfs_buf_log_item");
	xfs_da_state_zone = libxfs_zone_init(
			sizeof(xfs_da_state_t), "xfs_da_state");
	xfs_btree_cur_zone = libxfs_zone_init(
			sizeof(xfs_btree_cur_t), "xfs_btree_cur");
	xfs_bmap_free_item_zone = libxfs_zone_init(
			sizeof(xfs_bmap_free_item_t), "xfs_bmap_free_item");
	xfs_dir_startup();
}

/*
 * Get the bitmap and summary inodes into the mount structure
 * at mount time.
 */
static int
rtmount_inodes(xfs_mount_t *mp)
{
	int		error;
	xfs_sb_t	*sbp;

	sbp = &mp->m_sb;
	if (sbp->sb_rbmino == NULLFSINO)
		return 0;
	error = libxfs_iread(mp, NULL, sbp->sb_rbmino, &mp->m_rbmip, 0);
	if (error) {
		fprintf(stderr, "%s: cannot read realtime bitmap inode (%d)\n",
			progname, error);
		return error;
	}
	ASSERT(mp->m_rbmip != NULL);
	ASSERT(sbp->sb_rsumino != NULLFSINO);
	error = libxfs_iread(mp, NULL, sbp->sb_rsumino, &mp->m_rsumip, 0);
	if (error) {
		fprintf(stderr, "%s: cannot read realtime summary inode (%d)\n",
			progname, error);
		return error;
	}
	ASSERT(mp->m_rsumip != NULL);
	return 0;
}

/*
 * Mount structure initialization, provides a filled-in xfs_mount_t
 * such that the numerous XFS_* macros can be used.  If dev is zero,
 * no IO will be performed (no size checks, read root inodes).
 */
xfs_mount_t *
libxfs_mount(
	xfs_mount_t	*mp,
	xfs_sb_t	*sb,
	dev_t		dev,
	dev_t		logdev,
	dev_t		rtdev,
	int		rrootinos)
{
	xfs_daddr_t	d;
	xfs_buf_t	*bp;
	xfs_sb_t	*sbp;
	size_t		size;
	int		error;

	mp->m_dev = dev;
	mp->m_rtdev = rtdev;
	mp->m_logdev = logdev;
	mp->m_sb = *sb;
	sbp = &(mp->m_sb);
	manage_zones(0);

	libxfs_mount_common(mp, sb);

	libxfs_alloc_compute_maxlevels(mp);
	libxfs_bmap_compute_maxlevels(mp, XFS_DATA_FORK);
	libxfs_bmap_compute_maxlevels(mp, XFS_ATTR_FORK);
	libxfs_ialloc_compute_maxlevels(mp);

	if (sbp->sb_imax_pct) {
		/* Make sure the maximum inode count is a multiple of the
		 * units we allocate inodes in.
		 */
		mp->m_maxicount = (sbp->sb_dblocks * sbp->sb_imax_pct) / 100;
		mp->m_maxicount = ((mp->m_maxicount / mp->m_ialloc_blks) *
				  mp->m_ialloc_blks)  << sbp->sb_inopblog;
	} else
		mp->m_maxicount = 0;

	mp->m_inode_cluster_size = XFS_INODE_BIG_CLUSTER_SIZE;

	/*
	 * Set whether we're using inode alignment.
	 */
	if (XFS_SB_VERSION_HASALIGN(&mp->m_sb) &&
	    mp->m_sb.sb_inoalignmt >=
	    XFS_B_TO_FSBT(mp, mp->m_inode_cluster_size))
		mp->m_inoalign_mask = mp->m_sb.sb_inoalignmt - 1;
	else
		mp->m_inoalign_mask = 0;
	/*
	 * If we are using stripe alignment, check whether
	 * the stripe unit is a multiple of the inode alignment
	 */
	if (   mp->m_dalign
	    && mp->m_inoalign_mask && !(mp->m_dalign & mp->m_inoalign_mask))
		mp->m_sinoalign = mp->m_dalign;
	else
		mp->m_sinoalign = 0;

	/*
	 * Check that the data (and log if separate) are an ok size.
	 */
	d = (xfs_daddr_t)XFS_FSB_TO_BB(mp, mp->m_sb.sb_dblocks);
	if (XFS_BB_TO_FSB(mp, d) != mp->m_sb.sb_dblocks) {
		fprintf(stderr, "%s: size check failed\n", progname);
		return NULL;
	}

	/* Initialize the appropriate directory manager */
	if (XFS_SB_VERSION_HASDIRV2(sbp))
		libxfs_dir2_mount(mp);
	else
		libxfs_dir_mount(mp);

	/* Initialize the precomputed transaction reservations values */
	libxfs_trans_init(mp);

	if (dev == 0)	/* maxtrres, we have no device so leave now */
		return mp;

	bp = libxfs_readbuf(mp->m_dev, d - 1, 1, 0);
	if (bp == NULL) {
		fprintf(stderr, "%s: data size check failed\n", progname);
		return NULL;
	}
	libxfs_putbuf(bp);

	if (mp->m_logdev && mp->m_logdev != mp->m_dev) {
		d = (xfs_daddr_t)XFS_FSB_TO_BB(mp, mp->m_sb.sb_logblocks);
		if ( (XFS_BB_TO_FSB(mp, d) != mp->m_sb.sb_logblocks) ||
		     (!(bp = libxfs_readbuf(mp->m_logdev, d - 1, 1, 1)))) {
			fprintf(stderr, "%s: log size checks failed\n",
					progname);
			return NULL;
		}
		libxfs_putbuf(bp);
	}

	/* Initialize realtime fields in the mount structure */
	if (libxfs_rtmount_init(mp)) {
		fprintf(stderr, "%s: real-time device init failed\n", progname);
		return NULL;
	}

	/* Allocate and initialize the per-ag data */
	size = sbp->sb_agcount * sizeof(xfs_perag_t);
	if ((mp->m_perag = calloc(size, 1)) == NULL) {
		fprintf(stderr, "%s: failed to alloc %d bytes: %s\n",
			progname, size, strerror(errno));
		exit(1);
	}

	/*
	 * mkfs calls mount before the root inode is allocated.
	 */
	if (rrootinos && sbp->sb_rootino != NULLFSINO) {
		error = libxfs_iread(mp, NULL, sbp->sb_rootino,
				&mp->m_rootip, 0);
		if (error) {
			fprintf(stderr, "%s: cannot read root inode (%d)\n",
				progname, error);
			return NULL;
		}
		ASSERT(mp->m_rootip != NULL);
	}
	if (rrootinos && rtmount_inodes(mp))
		return NULL;
	return mp;
}

/*
 * Release any resourse obtained during a mount.
 */
void
libxfs_umount(xfs_mount_t *mp)
{
	manage_zones(1);
	free(mp->m_perag);
}