2 * SPDX-License-Identifier: BSD-2-Clause-FreeBSD
4 * Copyright (c) 2019 The FreeBSD Foundation
6 * This software was developed by BFF Storage Systems, LLC under sponsorship
7 * from the FreeBSD Foundation.
9 * Redistribution and use in source and binary forms, with or without
10 * modification, are permitted provided that the following conditions
12 * 1. Redistributions of source code must retain the above copyright
13 * notice, this list of conditions and the following disclaimer.
14 * 2. Redistributions in binary form must reproduce the above copyright
15 * notice, this list of conditions and the following disclaimer in the
16 * documentation and/or other materials provided with the distribution.
18 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
19 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
20 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
21 * ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
22 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
23 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
24 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
25 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
26 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
27 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
38 using namespace testing;
40 class Mkdir: public FuseTest {};
41 class Mkdir_7_8: public FuseTest {
43 virtual void SetUp() {
44 m_kernel_minor_version = 8;
50 * EMLINK is possible on filesystems that limit the number of hard links to a
51 * single file, like early versions of BtrFS
55 const char FULLPATH[] = "mountpoint/some_dir";
56 const char RELPATH[] = "some_dir";
59 EXPECT_LOOKUP(FUSE_ROOT_ID, RELPATH)
60 .WillOnce(Invoke(ReturnErrno(ENOENT)));
62 EXPECT_CALL(*m_mock, process(
63 ResultOf([=](auto in) {
64 const char *name = (const char*)in.body.bytes +
65 sizeof(fuse_mkdir_in);
66 return (in.header.opcode == FUSE_MKDIR &&
67 in.body.mkdir.mode == (S_IFDIR | mode) &&
68 (0 == strcmp(RELPATH, name)));
71 ).WillOnce(Invoke(ReturnErrno(EMLINK)));
73 ASSERT_NE(1, mkdir(FULLPATH, mode));
74 ASSERT_EQ(EMLINK, errno);
78 * Creating a new directory after FUSE_LOOKUP returned a negative cache entry
80 TEST_F(Mkdir, entry_cache_negative)
82 const char FULLPATH[] = "mountpoint/some_file.txt";
83 const char RELPATH[] = "some_file.txt";
87 * Set entry_valid = 0 because this test isn't concerned with whether
88 * or not we actually cache negative entries, only with whether we
89 * interpret negative cache responses correctly.
91 struct timespec entry_valid = {.tv_sec = 0, .tv_nsec = 0};
93 /* mkdir will first do a LOOKUP, adding a negative cache entry */
94 EXPECT_LOOKUP(FUSE_ROOT_ID, RELPATH)
95 .WillOnce(ReturnNegativeCache(&entry_valid));
97 EXPECT_CALL(*m_mock, process(
98 ResultOf([=](auto in) {
99 const char *name = (const char*)in.body.bytes +
100 sizeof(fuse_open_in);
101 return (in.header.opcode == FUSE_MKDIR &&
102 in.body.mkdir.mode == (S_IFDIR | mode) &&
103 (0 == strcmp(RELPATH, name)));
106 ).WillOnce(Invoke(ReturnImmediate([=](auto in __unused, auto& out) {
107 SET_OUT_HEADER_LEN(out, entry);
108 out.body.create.entry.attr.mode = S_IFDIR | mode;
109 out.body.create.entry.nodeid = ino;
110 out.body.create.entry.entry_valid = UINT64_MAX;
111 out.body.create.entry.attr_valid = UINT64_MAX;
114 ASSERT_EQ(0, mkdir(FULLPATH, mode)) << strerror(errno);
118 * Creating a new directory should purge any negative namecache entries
120 TEST_F(Mkdir, entry_cache_negative_purge)
122 const char FULLPATH[] = "mountpoint/some_file.txt";
123 const char RELPATH[] = "some_file.txt";
126 struct timespec entry_valid = {.tv_sec = TIME_T_MAX, .tv_nsec = 0};
128 /* mkdir will first do a LOOKUP, adding a negative cache entry */
129 EXPECT_LOOKUP(FUSE_ROOT_ID, RELPATH)
131 .WillOnce(Invoke(ReturnNegativeCache(&entry_valid)))
132 .RetiresOnSaturation();
134 /* Then the MKDIR should purge the negative cache entry */
135 EXPECT_CALL(*m_mock, process(
136 ResultOf([=](auto in) {
137 const char *name = (const char*)in.body.bytes +
138 sizeof(fuse_open_in);
139 return (in.header.opcode == FUSE_MKDIR &&
140 in.body.mkdir.mode == (S_IFDIR | mode) &&
141 (0 == strcmp(RELPATH, name)));
144 ).WillOnce(Invoke(ReturnImmediate([=](auto in __unused, auto& out) {
145 SET_OUT_HEADER_LEN(out, entry);
146 out.body.entry.attr.mode = S_IFDIR | mode;
147 out.body.entry.nodeid = ino;
148 out.body.entry.attr_valid = UINT64_MAX;
151 ASSERT_EQ(0, mkdir(FULLPATH, mode)) << strerror(errno);
153 /* Finally, a subsequent lookup should query the daemon */
154 expect_lookup(RELPATH, ino, S_IFDIR | mode, 0, 1);
156 ASSERT_EQ(0, access(FULLPATH, F_OK)) << strerror(errno);
161 const char FULLPATH[] = "mountpoint/some_dir";
162 const char RELPATH[] = "some_dir";
170 EXPECT_LOOKUP(FUSE_ROOT_ID, RELPATH)
171 .WillOnce(Invoke(ReturnErrno(ENOENT)));
173 EXPECT_CALL(*m_mock, process(
174 ResultOf([=](auto in) {
175 const char *name = (const char*)in.body.bytes +
176 sizeof(fuse_mkdir_in);
177 return (in.header.opcode == FUSE_MKDIR &&
178 in.body.mkdir.mode == (S_IFDIR | mode) &&
179 in.body.mkdir.umask == mask &&
180 (0 == strcmp(RELPATH, name)));
183 ).WillOnce(Invoke(ReturnImmediate([=](auto in __unused, auto& out) {
184 SET_OUT_HEADER_LEN(out, entry);
185 out.body.create.entry.attr.mode = S_IFDIR | mode;
186 out.body.create.entry.nodeid = ino;
187 out.body.create.entry.entry_valid = UINT64_MAX;
188 out.body.create.entry.attr_valid = UINT64_MAX;
191 ASSERT_EQ(0, mkdir(FULLPATH, mode)) << strerror(errno);
194 TEST_F(Mkdir_7_8, ok)
196 const char FULLPATH[] = "mountpoint/some_dir";
197 const char RELPATH[] = "some_dir";
201 EXPECT_LOOKUP(FUSE_ROOT_ID, RELPATH)
202 .WillOnce(Invoke(ReturnErrno(ENOENT)));
204 EXPECT_CALL(*m_mock, process(
205 ResultOf([=](auto in) {
206 const char *name = (const char*)in.body.bytes +
207 sizeof(fuse_mkdir_in);
208 return (in.header.opcode == FUSE_MKDIR &&
209 in.body.mkdir.mode == (S_IFDIR | mode) &&
210 (0 == strcmp(RELPATH, name)));
213 ).WillOnce(Invoke(ReturnImmediate([=](auto in __unused, auto& out) {
214 SET_OUT_HEADER_LEN(out, entry_7_8);
215 out.body.create.entry.attr.mode = S_IFDIR | mode;
216 out.body.create.entry.nodeid = ino;
217 out.body.create.entry.entry_valid = UINT64_MAX;
218 out.body.create.entry.attr_valid = UINT64_MAX;
221 ASSERT_EQ(0, mkdir(FULLPATH, mode)) << strerror(errno);