BlockStorage/repertory
1
0
Fork 0
Code Issues 8 Pull Requests Releases 6 Wiki Activity

refactor

Browse Source
This commit is contained in:
Scott E. Graves 2025-04-22 08:17:16 -05:00
parent 528fd595ab
commit 92d6633f44
1 changed files with 33 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

59
repertory/librepertory/include/drives/remote/remote_server_base.hpp
View File

@ -262,6 +262,31 @@ private:
return this->fuse_ftruncate(path.c_str(), size, handle); return this->fuse_ftruncate(path.c_str(), size, handle);
} }
[[nodiscard]] auto handle_fuse_getattr(packet *request, packet &response)
-> packet::error_type {
auto ret{0};
std::string path;
DECODE_OR_RETURN(request, path);
remote::user_id uid;
DECODE_OR_RETURN(request, uid);
remote::group_id gid;
DECODE_OR_RETURN(request, gid);
remote::stat st{};
bool directory = false;
ret = this->fuse_getattr(path.c_str(), st, directory);
if (ret == 0) {
st.st_uid = uid;
st.st_gid = gid;
response.encode(st);
response.encode(static_cast<std::uint8_t>(directory));
}
return ret;
}
private: private:
const std::unordered_map<std::string, handler_callback> handler_lookup_ = { const std::unordered_map<std::string, handler_callback> handler_lookup_ = {
{ {
@ -368,32 +393,14 @@ private:
return this->handle_fuse_ftruncate(request); return this->handle_fuse_ftruncate(request);
}, },
}, },
{"::fuse_getattr", {
[this](std::uint32_t, const std::string &, std::uint64_t, "::fuse_getattr",
const std::string &, packet *request, [this](auto && /* service_flags */, auto && /* client_id */,
packet &response) -> packet::error_type { auto && /* thread_id */, auto && /* method */, auto &&request,
auto ret{0}; auto &&response) -> auto {
return this->handle_fuse_getattr(request, response);
std::string path; },
DECODE_OR_RETURN(request, path); },
remote::user_id uid;
DECODE_OR_RETURN(request, uid);
remote::group_id gid;
DECODE_OR_RETURN(request, gid);
remote::stat st{};
bool directory = false;
ret = this->fuse_getattr(path.c_str(), st, directory);
if (ret == 0) {
st.st_uid = uid;
st.st_gid = gid;
response.encode(st);
response.encode(static_cast<std::uint8_t>(directory));
}
return ret;
}},
/*handlerLookup_.insert({"::fuse_getxattr", /*handlerLookup_.insert({"::fuse_getxattr",
[this](std::uint32_t serviceFlags, const [this](std::uint32_t serviceFlags, const
std::string &client_id, std::uint64_t threadId, const std::string std::string &client_id, std::uint64_t threadId, const std::string