19821f1d3SAlan Somers /*-
24d846d26SWarner Losh * SPDX-License-Identifier: BSD-2-Clause
39821f1d3SAlan Somers *
49821f1d3SAlan Somers * Copyright (c) 2019 The FreeBSD Foundation
59821f1d3SAlan Somers *
69821f1d3SAlan Somers * This software was developed by BFF Storage Systems, LLC under sponsorship
79821f1d3SAlan Somers * from the FreeBSD Foundation.
89821f1d3SAlan Somers *
99821f1d3SAlan Somers * Redistribution and use in source and binary forms, with or without
109821f1d3SAlan Somers * modification, are permitted provided that the following conditions
119821f1d3SAlan Somers * are met:
129821f1d3SAlan Somers * 1. Redistributions of source code must retain the above copyright
139821f1d3SAlan Somers * notice, this list of conditions and the following disclaimer.
149821f1d3SAlan Somers * 2. Redistributions in binary form must reproduce the above copyright
159821f1d3SAlan Somers * notice, this list of conditions and the following disclaimer in the
169821f1d3SAlan Somers * documentation and/or other materials provided with the distribution.
179821f1d3SAlan Somers *
189821f1d3SAlan Somers * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
199821f1d3SAlan Somers * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
209821f1d3SAlan Somers * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
219821f1d3SAlan Somers * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
229821f1d3SAlan Somers * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
239821f1d3SAlan Somers * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
249821f1d3SAlan Somers * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
259821f1d3SAlan Somers * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
269821f1d3SAlan Somers * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
279821f1d3SAlan Somers * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
289821f1d3SAlan Somers * SUCH DAMAGE.
299821f1d3SAlan Somers */
309821f1d3SAlan Somers
319821f1d3SAlan Somers extern "C" {
329821f1d3SAlan Somers #include <aio.h>
339821f1d3SAlan Somers #include <fcntl.h>
349821f1d3SAlan Somers #include <unistd.h>
359821f1d3SAlan Somers }
369821f1d3SAlan Somers
379821f1d3SAlan Somers #include "mockfs.hh"
389821f1d3SAlan Somers #include "utils.hh"
399821f1d3SAlan Somers
409821f1d3SAlan Somers using namespace testing;
419821f1d3SAlan Somers
429821f1d3SAlan Somers /*
439821f1d3SAlan Somers * TODO: remove FUSE_FSYNC_FDATASYNC definition when upgrading to protocol 7.28.
449821f1d3SAlan Somers * This bit was actually part of kernel protocol version 5.2, but never
459821f1d3SAlan Somers * documented until after 7.28
469821f1d3SAlan Somers */
479821f1d3SAlan Somers #ifndef FUSE_FSYNC_FDATASYNC
489821f1d3SAlan Somers #define FUSE_FSYNC_FDATASYNC 1
499821f1d3SAlan Somers #endif
509821f1d3SAlan Somers
519821f1d3SAlan Somers class FsyncDir: public FuseTest {
529821f1d3SAlan Somers public:
expect_fsyncdir(uint64_t ino,uint32_t flags,int error)539821f1d3SAlan Somers void expect_fsyncdir(uint64_t ino, uint32_t flags, int error)
549821f1d3SAlan Somers {
559821f1d3SAlan Somers EXPECT_CALL(*m_mock, process(
569821f1d3SAlan Somers ResultOf([=](auto in) {
5729edc611SAlan Somers return (in.header.opcode == FUSE_FSYNCDIR &&
5829edc611SAlan Somers in.header.nodeid == ino &&
5946c37cd0SAlan Somers /*
6046c37cd0SAlan Somers * TODO: reenable pid check after fixing
6146c37cd0SAlan Somers * bug 236379
6246c37cd0SAlan Somers */
6329edc611SAlan Somers //(pid_t)in.header.pid == getpid() &&
6429edc611SAlan Somers in.body.fsyncdir.fh == FH &&
6529edc611SAlan Somers in.body.fsyncdir.fsync_flags == flags);
669821f1d3SAlan Somers }, Eq(true)),
679821f1d3SAlan Somers _)
689821f1d3SAlan Somers ).WillOnce(Invoke(ReturnErrno(error)));
699821f1d3SAlan Somers }
709821f1d3SAlan Somers
expect_lookup(const char * relpath,uint64_t ino)719821f1d3SAlan Somers void expect_lookup(const char *relpath, uint64_t ino)
729821f1d3SAlan Somers {
739821f1d3SAlan Somers FuseTest::expect_lookup(relpath, ino, S_IFDIR | 0755, 0, 1);
749821f1d3SAlan Somers }
759821f1d3SAlan Somers
769821f1d3SAlan Somers };
779821f1d3SAlan Somers
78c2265ae7SAlan Somers class AioFsyncDir: public FsyncDir {
SetUp()79c2265ae7SAlan Somers virtual void SetUp() {
80c2265ae7SAlan Somers if (!is_unsafe_aio_enabled())
81c2265ae7SAlan Somers GTEST_SKIP() <<
82c2265ae7SAlan Somers "vfs.aio.enable_unsafe must be set for this test";
83c2265ae7SAlan Somers FuseTest::SetUp();
84c2265ae7SAlan Somers }
85c2265ae7SAlan Somers };
86c2265ae7SAlan Somers
879821f1d3SAlan Somers /* https://bugs.freebsd.org/bugzilla/show_bug.cgi?id=236379 */
TEST_F(AioFsyncDir,aio_fsync)88c2265ae7SAlan Somers TEST_F(AioFsyncDir, aio_fsync)
899821f1d3SAlan Somers {
909821f1d3SAlan Somers const char FULLPATH[] = "mountpoint/some_file.txt";
919821f1d3SAlan Somers const char RELPATH[] = "some_file.txt";
929821f1d3SAlan Somers uint64_t ino = 42;
939821f1d3SAlan Somers struct aiocb iocb, *piocb;
949821f1d3SAlan Somers int fd;
959821f1d3SAlan Somers
969821f1d3SAlan Somers expect_lookup(RELPATH, ino);
979821f1d3SAlan Somers expect_opendir(ino);
989821f1d3SAlan Somers expect_fsyncdir(ino, 0, 0);
999821f1d3SAlan Somers
1009821f1d3SAlan Somers fd = open(FULLPATH, O_DIRECTORY);
1019821f1d3SAlan Somers ASSERT_LE(0, fd) << strerror(errno);
1029821f1d3SAlan Somers
1039821f1d3SAlan Somers bzero(&iocb, sizeof(iocb));
1049821f1d3SAlan Somers iocb.aio_fildes = fd;
1059821f1d3SAlan Somers
1069821f1d3SAlan Somers ASSERT_EQ(0, aio_fsync(O_SYNC, &iocb)) << strerror(errno);
1079821f1d3SAlan Somers ASSERT_EQ(0, aio_waitcomplete(&piocb, NULL)) << strerror(errno);
1089821f1d3SAlan Somers
1097fc0921dSAlan Somers leak(fd);
1109821f1d3SAlan Somers }
1119821f1d3SAlan Somers
TEST_F(FsyncDir,eio)11246c37cd0SAlan Somers TEST_F(FsyncDir, eio)
1139821f1d3SAlan Somers {
1149821f1d3SAlan Somers const char FULLPATH[] = "mountpoint/some_dir";
1159821f1d3SAlan Somers const char RELPATH[] = "some_dir";
1169821f1d3SAlan Somers uint64_t ino = 42;
1179821f1d3SAlan Somers int fd;
1189821f1d3SAlan Somers
1199821f1d3SAlan Somers expect_lookup(RELPATH, ino);
1209821f1d3SAlan Somers expect_opendir(ino);
1219821f1d3SAlan Somers expect_fsyncdir(ino, 0, EIO);
1229821f1d3SAlan Somers
1239821f1d3SAlan Somers fd = open(FULLPATH, O_DIRECTORY);
1249821f1d3SAlan Somers ASSERT_LE(0, fd) << strerror(errno);
1259821f1d3SAlan Somers ASSERT_NE(0, fsync(fd));
1269821f1d3SAlan Somers ASSERT_EQ(EIO, errno);
1279821f1d3SAlan Somers
1287fc0921dSAlan Somers leak(fd);
1299821f1d3SAlan Somers }
1309821f1d3SAlan Somers
1319821f1d3SAlan Somers /*
1329821f1d3SAlan Somers * If the filesystem returns ENOSYS, it will be treated as success and
1339821f1d3SAlan Somers * subsequent calls to VOP_FSYNC will succeed automatically without being sent
1349821f1d3SAlan Somers * to the filesystem daemon
1359821f1d3SAlan Somers */
TEST_F(FsyncDir,enosys)1361f4a83f9SAlan Somers TEST_F(FsyncDir, enosys)
1379821f1d3SAlan Somers {
1389821f1d3SAlan Somers const char FULLPATH[] = "mountpoint/some_dir";
1399821f1d3SAlan Somers const char RELPATH[] = "some_dir";
1409821f1d3SAlan Somers uint64_t ino = 42;
1419821f1d3SAlan Somers int fd;
1429821f1d3SAlan Somers
1439821f1d3SAlan Somers expect_lookup(RELPATH, ino);
1449821f1d3SAlan Somers expect_opendir(ino);
1451f4a83f9SAlan Somers expect_fsyncdir(ino, 0, ENOSYS);
1469821f1d3SAlan Somers
1479821f1d3SAlan Somers fd = open(FULLPATH, O_DIRECTORY);
1489821f1d3SAlan Somers ASSERT_LE(0, fd) << strerror(errno);
1499821f1d3SAlan Somers EXPECT_EQ(0, fsync(fd)) << strerror(errno);
1509821f1d3SAlan Somers
1519821f1d3SAlan Somers /* Subsequent calls shouldn't query the daemon*/
1529821f1d3SAlan Somers EXPECT_EQ(0, fsync(fd)) << strerror(errno);
1539821f1d3SAlan Somers
1547fc0921dSAlan Somers leak(fd);
1559821f1d3SAlan Somers }
1569821f1d3SAlan Somers
TEST_F(FsyncDir,fsyncdata)15746c37cd0SAlan Somers TEST_F(FsyncDir, fsyncdata)
1589821f1d3SAlan Somers {
1599821f1d3SAlan Somers const char FULLPATH[] = "mountpoint/some_dir";
1609821f1d3SAlan Somers const char RELPATH[] = "some_dir";
1619821f1d3SAlan Somers uint64_t ino = 42;
1629821f1d3SAlan Somers int fd;
1639821f1d3SAlan Somers
1649821f1d3SAlan Somers expect_lookup(RELPATH, ino);
1659821f1d3SAlan Somers expect_opendir(ino);
1669821f1d3SAlan Somers expect_fsyncdir(ino, FUSE_FSYNC_FDATASYNC, 0);
1679821f1d3SAlan Somers
1689821f1d3SAlan Somers fd = open(FULLPATH, O_DIRECTORY);
1699821f1d3SAlan Somers ASSERT_LE(0, fd) << strerror(errno);
1709821f1d3SAlan Somers ASSERT_EQ(0, fdatasync(fd)) << strerror(errno);
1719821f1d3SAlan Somers
1727fc0921dSAlan Somers leak(fd);
1739821f1d3SAlan Somers }
1749821f1d3SAlan Somers
1759821f1d3SAlan Somers /*
1769821f1d3SAlan Somers * Unlike regular files, the kernel doesn't know whether a directory is or
1779821f1d3SAlan Somers * isn't dirty, so fuse(4) should always send FUSE_FSYNCDIR on fsync(2)
1789821f1d3SAlan Somers */
TEST_F(FsyncDir,fsync)17946c37cd0SAlan Somers TEST_F(FsyncDir, fsync)
1809821f1d3SAlan Somers {
1819821f1d3SAlan Somers const char FULLPATH[] = "mountpoint/some_dir";
1829821f1d3SAlan Somers const char RELPATH[] = "some_dir";
1839821f1d3SAlan Somers uint64_t ino = 42;
1849821f1d3SAlan Somers int fd;
1859821f1d3SAlan Somers
1869821f1d3SAlan Somers expect_lookup(RELPATH, ino);
1879821f1d3SAlan Somers expect_opendir(ino);
1889821f1d3SAlan Somers expect_fsyncdir(ino, 0, 0);
1899821f1d3SAlan Somers
1909821f1d3SAlan Somers fd = open(FULLPATH, O_DIRECTORY);
1919821f1d3SAlan Somers ASSERT_LE(0, fd) << strerror(errno);
1929821f1d3SAlan Somers ASSERT_EQ(0, fsync(fd)) << strerror(errno);
1939821f1d3SAlan Somers
1947fc0921dSAlan Somers leak(fd);
1959821f1d3SAlan Somers }
196