mirror of
https://github.com/falk-werner/webfuse
synced 2024-10-27 20:34:10 +00:00
add test for read
This commit is contained in:
parent
380e46f0da
commit
861671741f
@ -85,6 +85,7 @@ if(NOT(WITHOUT_TEST))
|
|||||||
test-src/integration/test_open.cpp
|
test-src/integration/test_open.cpp
|
||||||
test-src/integration/test_mknod.cpp
|
test-src/integration/test_mknod.cpp
|
||||||
test-src/integration/test_unlink.cpp
|
test-src/integration/test_unlink.cpp
|
||||||
|
test-src/integration/test_read.cpp
|
||||||
)
|
)
|
||||||
|
|
||||||
target_include_directories(integration_tests PRIVATE test-src/integration ${GTEST_INCLUDE_DIRS} ${GMOCK_INCLUDE_DIRS})
|
target_include_directories(integration_tests PRIVATE test-src/integration ${GTEST_INCLUDE_DIRS} ${GMOCK_INCLUDE_DIRS})
|
||||||
|
@ -103,6 +103,9 @@ public:
|
|||||||
case request_type::unlink:
|
case request_type::unlink:
|
||||||
fs_unlink(reader, writer);
|
fs_unlink(reader, writer);
|
||||||
break;
|
break;
|
||||||
|
case request_type::read:
|
||||||
|
fs_read(reader, writer);
|
||||||
|
break;
|
||||||
case request_type::readdir:
|
case request_type::readdir:
|
||||||
fs_readdir(reader, writer);
|
fs_readdir(reader, writer);
|
||||||
break;
|
break;
|
||||||
@ -283,6 +286,23 @@ private:
|
|||||||
writer.write_i32(result);
|
writer.write_i32(result);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
void fs_read(messagereader & reader, messagewriter & writer)
|
||||||
|
{
|
||||||
|
auto const path = reader.read_str();
|
||||||
|
auto const size = reader.read_u32();
|
||||||
|
auto const offset = reader.read_u64();
|
||||||
|
auto const handle = reader.read_u64();
|
||||||
|
|
||||||
|
std::vector<char> buffer(size);
|
||||||
|
|
||||||
|
auto const result = fs_.read(path, buffer.data(), size, offset, handle);
|
||||||
|
writer.write_i32(result);
|
||||||
|
if (0 < result)
|
||||||
|
{
|
||||||
|
writer.write_data(buffer.data(), result);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
void fs_readdir(messagereader & reader, messagewriter & writer)
|
void fs_readdir(messagereader & reader, messagewriter & writer)
|
||||||
{
|
{
|
||||||
auto const path = reader.read_str();
|
auto const path = reader.read_str();
|
||||||
|
70
test-src/integration/test_read.cpp
Normal file
70
test-src/integration/test_read.cpp
Normal file
@ -0,0 +1,70 @@
|
|||||||
|
#include "webfuse/webfuse.hpp"
|
||||||
|
#include "webfuse/test/fixture.hpp"
|
||||||
|
#include "webfuse/test/filesystem_mock.hpp"
|
||||||
|
|
||||||
|
#include <gtest/gtest.h>
|
||||||
|
#include <fstream>
|
||||||
|
#include <sstream>
|
||||||
|
|
||||||
|
|
||||||
|
using testing::_;
|
||||||
|
using testing::Return;
|
||||||
|
using testing::Invoke;
|
||||||
|
using testing::AnyNumber;
|
||||||
|
using testing::AtMost;
|
||||||
|
|
||||||
|
TEST(read, success)
|
||||||
|
{
|
||||||
|
std::string expected = "Hello, World!";
|
||||||
|
|
||||||
|
webfuse::filesystem_mock fs;
|
||||||
|
EXPECT_CALL(fs, access("/",_)).Times(AnyNumber()).WillRepeatedly(Return(0));
|
||||||
|
EXPECT_CALL(fs, getattr(_,_)).WillRepeatedly(Invoke([&expected](std::string const & path, struct stat * attr){
|
||||||
|
memset(reinterpret_cast<void*>(attr),0, sizeof(struct stat));
|
||||||
|
|
||||||
|
if (path == "/")
|
||||||
|
{
|
||||||
|
attr->st_nlink = 1;
|
||||||
|
attr->st_mode = S_IFDIR | 0755;
|
||||||
|
return 0;
|
||||||
|
}
|
||||||
|
if (path == "/some_file")
|
||||||
|
{
|
||||||
|
attr->st_nlink = 1;
|
||||||
|
attr->st_mode = S_IFREG | 0644;
|
||||||
|
attr->st_size = expected.size();
|
||||||
|
return 0;
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
return -ENOENT;
|
||||||
|
}
|
||||||
|
}));
|
||||||
|
EXPECT_CALL(fs, open("/some_file", _, _)).WillOnce(Return(0));
|
||||||
|
EXPECT_CALL(fs, read("/some_file", _, _, _, _)).Times(AnyNumber()).WillRepeatedly(Invoke([&expected](auto const &, char * buffer, size_t buffer_size, uint64_t offset, auto){
|
||||||
|
if (offset < expected.size())
|
||||||
|
{
|
||||||
|
auto const count = std::min(buffer_size, expected.size() - offset);
|
||||||
|
memcpy(reinterpret_cast<void*>(buffer), reinterpret_cast<void const *>(&expected[offset]), count);
|
||||||
|
return (int) count;
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
return 0;
|
||||||
|
}
|
||||||
|
}));
|
||||||
|
EXPECT_CALL(fs, release("/some_file", _)).Times(AtMost(1)).WillOnce(Return(0));
|
||||||
|
|
||||||
|
webfuse::fixture fixture(fs);
|
||||||
|
auto const path = fixture.get_path() + "/some_file";
|
||||||
|
|
||||||
|
std::string contents;
|
||||||
|
{
|
||||||
|
std::ifstream in(path);
|
||||||
|
std::stringstream buffer;
|
||||||
|
buffer << in.rdbuf();
|
||||||
|
contents = buffer.str();
|
||||||
|
}
|
||||||
|
|
||||||
|
ASSERT_EQ(expected, contents);
|
||||||
|
}
|
Loading…
Reference in New Issue
Block a user