@@ -10,7 +10,7 @@
#include "io.h"
#include "libfrog/logging.h"
#include "libfrog/fsgeom.h"
-#include "libfrog/bulkstat.h"
+#include "libfrog/file_exchange.h"
static cmdinfo_t swapext_cmd;
@@ -28,47 +28,47 @@ swapext_f(
int argc,
char **argv)
{
- struct xfs_fd fxfd = XFS_FD_INIT(file->fd);
- struct xfs_bulkstat bulkstat;
- int fd;
- int error;
- struct xfs_swapext sx;
+ struct xfs_fd xfd = XFS_FD_INIT(file->fd);
+ struct xfs_exch_range fxr;
struct stat stat;
+ uint64_t flags = XFS_EXCH_RANGE_FILE2_FRESH |
+ XFS_EXCH_RANGE_FULL_FILES;
+ int fd;
+ int ret;
/* open the donor file */
fd = openfile(argv[1], NULL, 0, 0, NULL);
if (fd < 0)
return 0;
- /*
- * stat the target file to get the inode number and use the latter to
- * get the bulkstat info for the swapext cmd.
- */
- error = fstat(file->fd, &stat);
- if (error) {
+ ret = -xfd_prepare_geometry(&xfd);
+ if (ret) {
+ xfrog_perror(ret, "xfd_prepare_geometry");
+ exitcode = 1;
+ goto out;
+ }
+
+ ret = fstat(file->fd, &stat);
+ if (ret) {
perror("fstat");
+ exitcode = 1;
goto out;
}
- error = -xfrog_bulkstat_single(&fxfd, stat.st_ino, 0, &bulkstat);
- if (error) {
- xfrog_perror(error, "bulkstat");
+ ret = xfrog_file_exchange_prep(&xfd, flags, 0, fd, 0, stat.st_size,
+ &fxr);
+ if (ret) {
+ xfrog_perror(ret, "xfrog_file_exchange_prep");
+ exitcode = 1;
goto out;
}
- error = -xfrog_bulkstat_v5_to_v1(&fxfd, &sx.sx_stat, &bulkstat);
- if (error) {
- xfrog_perror(error, "bulkstat conversion");
+
+ ret = xfrog_file_exchange(&xfd, &fxr);
+ if (ret) {
+ xfrog_perror(ret, "swapext");
+ exitcode = 1;
goto out;
}
- sx.sx_version = XFS_SX_VERSION;
- sx.sx_fdtarget = file->fd;
- sx.sx_fdtmp = fd;
- sx.sx_offset = 0;
- sx.sx_length = stat.st_size;
- error = ioctl(file->fd, XFS_IOC_SWAPEXT, &sx);
- if (error)
- perror("swapext");
-
out:
close(fd);
return 0;
@@ -18,6 +18,7 @@ bitmap.c \
bulkstat.c \
convert.c \
crc32.c \
+file_exchange.c \
fsgeom.c \
list_sort.c \
linux.c \
@@ -42,6 +43,7 @@ crc32defs.h \
crc32table.h \
dahashselftest.h \
div64.h \
+file_exchange.h \
fsgeom.h \
logging.h \
paths.h \
new file mode 100644
@@ -0,0 +1,169 @@
+// SPDX-License-Identifier: GPL-2.0-or-later
+/*
+ * Copyright (c) 2020-2024 Oracle. All Rights Reserved.
+ * Author: Darrick J. Wong <djwong@kernel.org>
+ */
+#include <sys/types.h>
+#include <sys/stat.h>
+#include <sys/ioctl.h>
+#include <unistd.h>
+#include <string.h>
+#include "xfs.h"
+#include "fsgeom.h"
+#include "bulkstat.h"
+#include "file_exchange.h"
+
+/* Prepare the freshness component of a swapext request. */
+static int
+xfrog_file_exchange_prep_freshness(
+ struct xfs_fd *dest,
+ struct xfs_exch_range *req)
+{
+ struct stat stat;
+ struct xfs_bulkstat bulkstat;
+ int error;
+
+ error = fstat(dest->fd, &stat);
+ if (error)
+ return -errno;
+ req->file2_ino = stat.st_ino;
+
+ /*
+ * Try to fill out the [cm]time data from bulkstat. We prefer this
+ * approach because bulkstat v5 gives us 64-bit time even on 32-bit.
+ *
+ * However, we'll take our chances on the C library if the filesystem
+ * supports 64-bit time but we ended up with bulkstat v5 emulation.
+ */
+ error = xfrog_bulkstat_single(dest, stat.st_ino, 0, &bulkstat);
+ if (!error &&
+ !((dest->fsgeom.flags & XFS_FSOP_GEOM_FLAGS_BIGTIME) &&
+ bulkstat.bs_version < XFS_BULKSTAT_VERSION_V5)) {
+ req->file2_mtime = bulkstat.bs_mtime;
+ req->file2_ctime = bulkstat.bs_ctime;
+ req->file2_mtime_nsec = bulkstat.bs_mtime_nsec;
+ req->file2_ctime_nsec = bulkstat.bs_ctime_nsec;
+ return 0;
+ }
+
+ /* Otherwise, use the stat information and hope for the best. */
+ req->file2_mtime = stat.st_mtime;
+ req->file2_ctime = stat.st_ctime;
+ req->file2_mtime_nsec = stat.st_mtim.tv_nsec;
+ req->file2_ctime_nsec = stat.st_ctim.tv_nsec;
+ return 0;
+}
+
+/* Prepare an extent swap request. */
+int
+xfrog_file_exchange_prep(
+ struct xfs_fd *dest,
+ uint64_t flags,
+ int64_t file2_offset,
+ int file1_fd,
+ int64_t file1_offset,
+ int64_t length,
+ struct xfs_exch_range *req)
+{
+ memset(req, 0, sizeof(*req));
+ req->file1_fd = file1_fd;
+ req->file1_offset = file1_offset;
+ req->length = length;
+ req->file2_offset = file2_offset;
+ req->flags = flags;
+
+ if (flags & XFS_EXCH_RANGE_FILE2_FRESH)
+ return xfrog_file_exchange_prep_freshness(dest, req);
+
+ return 0;
+}
+
+/* Swap two files' extents with the new exchange range ioctl. */
+static int
+xfrog_file_exchange_range(
+ struct xfs_fd *xfd,
+ struct xfs_exch_range *req)
+{
+ int ret;
+
+ ret = ioctl(xfd->fd, XFS_IOC_EXCHANGE_RANGE, req);
+ if (ret) {
+ /* the old swapext ioctl returned EFAULT for bad length */
+ if (errno == EDOM)
+ return -EFAULT;
+ return -errno;
+ }
+ return 0;
+}
+
+/*
+ * The old swapext ioctl did not provide atomic swap; it required that the
+ * supplied offset and length matched both files' lengths; and it also required
+ * that the sx_stat information match the dest file. It doesn't support any
+ * other flags.
+ */
+#define XFS_EXCH_RANGE_SWAPEXT (XFS_EXCH_RANGE_NONATOMIC | \
+ XFS_EXCH_RANGE_FULL_FILES | \
+ XFS_EXCH_RANGE_FILE2_FRESH)
+
+/* Swap two files' extents with the old xfs swapext ioctl. */
+static int
+xfrog_file_exchange_swapext(
+ struct xfs_fd *xfd,
+ struct xfs_exch_range *req)
+{
+ struct xfs_swapext sx = {
+ .sx_version = XFS_SX_VERSION,
+ .sx_fdtarget = xfd->fd,
+ .sx_fdtmp = req->file1_fd,
+ .sx_length = req->length,
+ };
+ int ret;
+
+ if (req->file1_offset != req->file2_offset)
+ return -EINVAL;
+ if (req->flags != XFS_EXCH_RANGE_SWAPEXT)
+ return -EOPNOTSUPP;
+
+ sx.sx_stat.bs_ino = req->file2_ino;
+ sx.sx_stat.bs_ctime.tv_sec = req->file2_ctime;
+ sx.sx_stat.bs_ctime.tv_nsec = req->file2_ctime_nsec;
+ sx.sx_stat.bs_mtime.tv_sec = req->file2_mtime;
+ sx.sx_stat.bs_mtime.tv_nsec = req->file2_mtime_nsec;
+
+ ret = ioctl(xfd->fd, XFS_IOC_SWAPEXT, &sx);
+ if (ret)
+ return -errno;
+ return 0;
+}
+
+/* Swap extents between an XFS file and a donor fd. */
+int
+xfrog_file_exchange(
+ struct xfs_fd *xfd,
+ struct xfs_exch_range *req)
+{
+ int error;
+
+ if (xfd->flags & XFROG_FLAG_FORCE_SWAPEXT)
+ goto try_swapext;
+
+ error = xfrog_file_exchange_range(xfd, req);
+ if ((error != -ENOTTY && error != -EOPNOTSUPP) ||
+ (xfd->flags & XFROG_FLAG_FORCE_EXCH_RANGE))
+ return error;
+
+ /*
+ * If the new exchange range ioctl wasn't found, punt to the old
+ * swapext ioctl.
+ */
+ switch (error) {
+ case -EOPNOTSUPP:
+ case -ENOTTY:
+ xfd->flags |= XFROG_FLAG_FORCE_SWAPEXT;
+ break;
+ }
+
+try_swapext:
+ return xfrog_file_exchange_swapext(xfd, req);
+}
new file mode 100644
@@ -0,0 +1,14 @@
+/* SPDX-License-Identifier: GPL-2.0-or-later */
+/*
+ * Copyright (c) 2020-2024 Oracle. All rights reserved.
+ * All Rights Reserved.
+ */
+#ifndef __LIBFROG_FILE_EXCHANGE_H__
+#define __LIBFROG_FILE_EXCHANGE_H__
+
+int xfrog_file_exchange_prep(struct xfs_fd *file2, uint64_t flags,
+ int64_t file2_offset, int file1_fd, int64_t file1_offset,
+ int64_t length, struct xfs_exch_range *req);
+int xfrog_file_exchange(struct xfs_fd *xfd, struct xfs_exch_range *req);
+
+#endif /* __LIBFROG_FILE_EXCHANGE_H__ */
@@ -50,6 +50,12 @@ struct xfs_fd {
/* Only use v5 bulkstat/inumbers ioctls. */
#define XFROG_FLAG_BULKSTAT_FORCE_V5 (1 << 1)
+/* Only use XFS_IOC_SWAPEXT for file data exchanges. */
+#define XFROG_FLAG_FORCE_SWAPEXT (1 << 2)
+
+/* Only use XFS_IOC_EXCHANGE_RANGE for file data exchanges. */
+#define XFROG_FLAG_FORCE_EXCH_RANGE (1 << 3)
+
/* Static initializers */
#define XFS_FD_INIT(_fd) { .fd = (_fd), }
#define XFS_FD_INIT_EMPTY XFS_FD_INIT(-1)