1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
|
use super::traits::ReplyOk;
use crate::{io::FsInfo, proto, sealed::Sealed, util::page_size, Done, Operation, Reply};
pub enum Init {}
pub enum Statfs {}
pub struct InitState {
pub(crate) kernel_flags: proto::InitFlags,
pub(crate) buffer_pages: usize,
}
pub trait ReplyFsInfo<'o>: Operation<'o> {
fn info(reply: Reply<'o, Self>, info: &FsInfo) -> Done<'o>;
}
impl Sealed for Init {}
impl Sealed for Statfs {}
impl<'o> Operation<'o> for Init {
type RequestBody = &'o proto::InitIn;
type ReplyState = InitState;
}
impl<'o> Operation<'o> for Statfs {
type RequestBody = ();
type ReplyState = ();
}
impl<'o> ReplyOk<'o> for Init {
fn ok(reply: Reply<'o, Self>) -> Done<'o> {
let InitState {
kernel_flags,
buffer_pages,
} = reply.state;
let flags = {
use proto::InitFlags;
//TODO: Conditions for these feature flags
// - Locks
// - ASYNC_DIO
// - WRITEBACK_CACHE
// - NO_OPEN_SUPPORT
// - HANDLE_KILLPRIV
// - POSIX_ACL
// - NO_OPENDIR_SUPPORT
// - EXPLICIT_INVAL_DATA
let supported = InitFlags::ASYNC_READ
| InitFlags::FILE_OPS
| InitFlags::ATOMIC_O_TRUNC
| InitFlags::EXPORT_SUPPORT
| InitFlags::BIG_WRITES
| InitFlags::HAS_IOCTL_DIR
| InitFlags::AUTO_INVAL_DATA
| InitFlags::DO_READDIRPLUS
| InitFlags::READDIRPLUS_AUTO
| InitFlags::PARALLEL_DIROPS
| InitFlags::ABORT_ERROR
| InitFlags::MAX_PAGES
| InitFlags::CACHE_SYMLINKS;
kernel_flags & supported
};
let buffer_size = page_size() * buffer_pages;
// See fs/fuse/dev.c in the kernel source tree for details about max_write
let max_write = buffer_size - std::mem::size_of::<(proto::InHeader, proto::WriteIn)>();
reply.single(&proto::InitOut {
major: proto::MAJOR_VERSION,
minor: proto::TARGET_MINOR_VERSION,
max_readahead: 0, //TODO
flags: flags.bits(),
max_background: 0, //TODO
congestion_threshold: 0, //TODO
max_write: max_write.try_into().unwrap(),
time_gran: 1, //TODO
max_pages: buffer_pages.try_into().unwrap(),
padding: Default::default(),
unused: Default::default(),
})
}
}
impl<'o> ReplyFsInfo<'o> for Statfs {
fn info(reply: Reply<'o, Self>, fs_info: &FsInfo) -> Done<'o> {
reply.single(&proto::StatfsOut::from(*fs_info))
}
}
|
