003 File Manager
Current Path:
/usr/src/tests/sys/fs/fusefs
usr
/
src
/
tests
/
sys
/
fs
/
fusefs
/
📁
..
📄
Makefile
(1.88 KB)
📄
access.cc
(8.25 KB)
📄
allow_other.cc
(7.55 KB)
📄
bmap.cc
(4.62 KB)
📄
cache.cc
(6.41 KB)
📄
copy_file_range.cc
(11.67 KB)
📄
create.cc
(12.79 KB)
📄
default_permissions.cc
(40.48 KB)
📄
default_permissions_privileged.cc
(3.75 KB)
📄
destroy.cc
(4.81 KB)
📄
dev_fuse_poll.cc
(6.62 KB)
📄
fifo.cc
(5.39 KB)
📄
flush.cc
(6.41 KB)
📄
forget.cc
(4.7 KB)
📄
fsync.cc
(7.84 KB)
📄
fsyncdir.cc
(5.11 KB)
📄
getattr.cc
(9.57 KB)
📄
interrupt.cc
(21.73 KB)
📄
io.cc
(13.88 KB)
📄
link.cc
(7.13 KB)
📄
locks.cc
(12.17 KB)
📄
lookup.cc
(11.8 KB)
📄
lseek.cc
(10.33 KB)
📄
mkdir.cc
(6.82 KB)
📄
mknod.cc
(6.68 KB)
📄
mockfs.cc
(26.08 KB)
📄
mockfs.hh
(12.04 KB)
📄
mount.cc
(4.96 KB)
📄
nfs.cc
(10.01 KB)
📄
notify.cc
(14.47 KB)
📄
open.cc
(7.18 KB)
📄
opendir.cc
(4.64 KB)
📄
read.cc
(24.69 KB)
📄
readdir.cc
(9.23 KB)
📄
readlink.cc
(3.62 KB)
📄
release.cc
(6.35 KB)
📄
releasedir.cc
(3.44 KB)
📄
rename.cc
(8.87 KB)
📄
rmdir.cc
(4.68 KB)
📄
setattr.cc
(23.89 KB)
📄
statfs.cc
(5.12 KB)
📄
symlink.cc
(5.29 KB)
📄
unlink.cc
(6.91 KB)
📄
utils.cc
(17.41 KB)
📄
utils.hh
(7.91 KB)
📄
write.cc
(38.98 KB)
📄
xattr.cc
(22.52 KB)
Editing: destroy.cc
/*- * SPDX-License-Identifier: BSD-2-Clause-FreeBSD * * Copyright (c) 2019 The FreeBSD Foundation * * This software was developed by BFF Storage Systems, LLC under sponsorship * from the FreeBSD Foundation. * * Redistribution and use in source and binary forms, with or without * modification, are permitted provided that the following conditions * are met: * 1. Redistributions of source code must retain the above copyright * notice, this list of conditions and the following disclaimer. * 2. Redistributions in binary form must reproduce the above copyright * notice, this list of conditions and the following disclaimer in the * documentation and/or other materials provided with the distribution. * * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF * SUCH DAMAGE. * * $FreeBSD$ */ extern "C" { #include <fcntl.h> #include <pthread.h> #include <semaphore.h> } #include "mockfs.hh" #include "utils.hh" using namespace testing; /* Tests for orderly unmounts */ class Destroy: public FuseTest {}; /* Tests for unexpected deaths of the server */ class Death: public FuseTest{}; static void* open_th(void* arg) { int fd; const char *path = (const char*)arg; fd = open(path, O_RDONLY); EXPECT_EQ(-1, fd); EXPECT_EQ(ENOTCONN, errno); return 0; } /* * The server dies with unsent operations still on the message queue. * Check for any memory leaks like this: * 1) kldunload fusefs, if necessary * 2) kldload fusefs * 3) ./destroy --gtest_filter=Destroy.unsent_operations * 4) kldunload fusefs * 5) check /var/log/messages for anything like this: Freed UMA keg (fuse_ticket) was not empty (31 items). Lost 2 pages of memory. Warning: memory type fuse_msgbuf leaked memory on destroy (68 allocations, 428800 bytes leaked). */ TEST_F(Death, unsent_operations) { const char FULLPATH0[] = "mountpoint/some_file.txt"; const char FULLPATH1[] = "mountpoint/other_file.txt"; const char RELPATH0[] = "some_file.txt"; const char RELPATH1[] = "other_file.txt"; pthread_t th0, th1; ino_t ino0 = 42, ino1 = 43; sem_t sem; mode_t mode = S_IFREG | 0644; sem_init(&sem, 0, 0); EXPECT_LOOKUP(FUSE_ROOT_ID, RELPATH0) .WillRepeatedly(Invoke( ReturnImmediate([=](auto in __unused, auto& out) { SET_OUT_HEADER_LEN(out, entry); out.body.entry.attr.mode = mode; out.body.entry.nodeid = ino0; out.body.entry.attr.nlink = 1; }))); EXPECT_LOOKUP(FUSE_ROOT_ID, RELPATH1) .WillRepeatedly(Invoke( ReturnImmediate([=](auto in __unused, auto& out) { SET_OUT_HEADER_LEN(out, entry); out.body.entry.attr.mode = mode; out.body.entry.nodeid = ino1; out.body.entry.attr.nlink = 1; }))); EXPECT_CALL(*m_mock, process( ResultOf([&](auto in) { return (in.header.opcode == FUSE_OPEN); }, Eq(true)), _) ).WillOnce(Invoke([&](auto in __unused, auto &out __unused) { sem_post(&sem); pause(); })); /* * One thread's operation will be sent to the daemon and block, and the * other's will be stuck in the message queue. */ ASSERT_EQ(0, pthread_create(&th0, NULL, open_th, __DECONST(void*, FULLPATH0))) << strerror(errno); ASSERT_EQ(0, pthread_create(&th1, NULL, open_th, __DECONST(void*, FULLPATH1))) << strerror(errno); /* Wait for the first thread to block */ sem_wait(&sem); /* Give the second thread time to block */ nap(); m_mock->kill_daemon(); pthread_join(th0, NULL); pthread_join(th1, NULL); sem_destroy(&sem); } /* * On unmount the kernel should send a FUSE_DESTROY operation. It should also * send FUSE_FORGET operations for all inodes with lookup_count > 0. */ TEST_F(Destroy, ok) { const char FULLPATH[] = "mountpoint/some_file.txt"; const char RELPATH[] = "some_file.txt"; uint64_t ino = 42; expect_lookup(RELPATH, ino, S_IFREG | 0644, 0, 2); expect_forget(FUSE_ROOT_ID, 1); expect_forget(ino, 2); expect_destroy(0); /* * access(2) the file to force a lookup. Access it twice to double its * lookup count. */ ASSERT_EQ(0, access(FULLPATH, F_OK)) << strerror(errno); ASSERT_EQ(0, access(FULLPATH, F_OK)) << strerror(errno); /* * Unmount, triggering a FUSE_DESTROY and also causing a VOP_RECLAIM * for every vnode on this mp, triggering FUSE_FORGET for each of them. */ m_mock->unmount(); }
Upload File
Create Folder