Archives/falk-werner_webfuse
1
0
Fork 0
mirror of https://github.com/falk-werner/webfuse synced 2026-03-02 03:40:24 +00:00
Code Issues Releases Wiki Activity

add test for fsync

Browse Source
This commit is contained in:
Falk Werner
2023-01-02 19:47:29 +01:00
parent ff25327eb5
commit 61b97f19aa
5 changed files with 105 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

42
src/webfuse/provider.cpp
View File

@@ -82,6 +82,15 @@ public:
case request_type::truncate:
fs_truncate(reader, writer);
break;
case request_type::fsync:
fs_fsync(reader, writer);
break;
case request_type::create:
fs_create(reader, writer);
break;
case request_type::release:
fs_release(reader, writer);
break;
case request_type::readdir:
fs_readdir(reader, writer);
break;
@@ -185,6 +194,39 @@ private:
writer.write_i32(result);
}
void fs_fsync(messagereader & reader, messagewriter & writer)
{
auto const path = reader.read_str();
auto const is_datasync = reader.read_bool();
auto const handle = reader.read_u64();
auto const result = fs_.fsync(path, is_datasync, handle);
writer.write_i32(result);
}
void fs_create(messagereader & reader, messagewriter & writer)
{
auto const path = reader.read_str();
auto const mode = reader.read_mode();
uint64_t handle = static_cast<uint64_t>(-1);
auto const result = fs_.create(path, mode, handle);
writer.write_i32(result);
if (result == 0)
{
writer.write_u64(handle);
}
}
void fs_release(messagereader & reader, messagewriter & writer)
{
auto const path = reader.read_str();
auto const handle = reader.read_u64();
auto const result = fs_.release(path, handle);
writer.write_i32(result);
}
void fs_readdir(messagereader & reader, messagewriter & writer)
{
auto const path = reader.read_str();

5
src/webfuse/ws/messagereader.cpp
View File

@@ -83,6 +83,11 @@ mode_t messagereader::read_mode()
return mode.to_mode();
}
bool messagereader::read_bool()
{
return (1 == read_u8());
}
uint8_t messagereader::read_u8()
{

1
src/webfuse/ws/messagereader.hpp
View File

@@ -29,6 +29,7 @@ public:
int read_access_mode();
mode_t read_mode();
bool read_bool();
uint8_t read_u8();
uint32_t read_u32();
uint64_t read_u64();