diff --git a/CMakeLists.txt b/CMakeLists.txt index 390ca87..e63b02c 100644 --- a/CMakeLists.txt +++ b/CMakeLists.txt @@ -83,6 +83,7 @@ if(NOT(WITHOUT_TEST)) test-src/integration/test_fsync.cpp test-src/integration/test_utimens.cpp test-src/integration/test_open.cpp + test-src/integration/test_mknod.cpp ) target_include_directories(integration_tests PRIVATE test-src/integration ${GTEST_INCLUDE_DIRS} ${GMOCK_INCLUDE_DIRS}) diff --git a/src/webfuse/provider.cpp b/src/webfuse/provider.cpp index e4a7dcd..124c038 100644 --- a/src/webfuse/provider.cpp +++ b/src/webfuse/provider.cpp @@ -91,6 +91,9 @@ public: case request_type::open: fs_open(reader, writer); break; + case request_type::mknod: + fs_mknod(reader, writer); + break; case request_type::create: fs_create(reader, writer); break; @@ -236,6 +239,16 @@ private: } } + void fs_mknod(messagereader & reader, messagewriter & writer) + { + auto const path = reader.read_str(); + auto const mode = reader.read_mode(); + auto const dev = reader.read_u32(); + + auto const result = fs_.mknod(path, mode, dev); + writer.write_i32(result); + } + void fs_create(messagereader & reader, messagewriter & writer) { auto const path = reader.read_str(); diff --git a/test-src/integration/test_mknod.cpp b/test-src/integration/test_mknod.cpp new file mode 100644 index 0000000..2af4234 --- /dev/null +++ b/test-src/integration/test_mknod.cpp @@ -0,0 +1,52 @@ +#include "webfuse/webfuse.hpp" +#include "webfuse/test/fixture.hpp" +#include "webfuse/test/filesystem_mock.hpp" + +#include +#include +#include + +using testing::_; +using testing::Return; +using testing::Invoke; +using testing::AnyNumber; +using testing::AtMost; + +TEST(mknod, success) +{ + bool file_created = false; + + webfuse::filesystem_mock fs; + EXPECT_CALL(fs, access("/",_)).Times(AnyNumber()).WillRepeatedly(Return(0)); + EXPECT_CALL(fs, getattr(_,_)).WillRepeatedly(Invoke([&file_created](std::string const & path, struct stat * attr){ + memset(reinterpret_cast(attr),0, sizeof(struct stat)); + + if (path == "/") + { + attr->st_nlink = 1; + attr->st_mode = S_IFDIR | 0755; + return 0; + } + else if ((path == "/some_dev") && (file_created)) + { + attr->st_nlink = 1; + attr->st_mode = S_IFIFO | 0644; + attr->st_size = 0; + return 0; + } + else + { + return -ENOENT; + } + })); + EXPECT_CALL(fs, mknod("/some_dev", _, _)).Times(AtMost(1)).WillOnce(Invoke([&file_created](auto const &, auto, auto ){ + file_created = true; + return 0; + })); + EXPECT_CALL(fs, release("/some_dev", _)).Times(AtMost(1)).WillOnce(Return(0)); + + webfuse::fixture fixture(fs); + auto const path = fixture.get_path() + "/some_dev"; + + ASSERT_EQ(0, ::mkfifo(path.c_str(), 0644)); +}