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
|
use std::{
ffi::{CStr, OsStr},
os::unix::ffi::OsStrExt,
};
use crate::{
private_trait::Sealed, proto, util::OutputChain, Done, Ino, Operation, Reply, Request, Ttl,
};
use bytemuck::{bytes_of, Pod};
pub mod traits;
pub use dir::{BufferedReaddir, Lookup, Readdir};
pub use entry::{Link, Mkdir, Mknod, Rmdir, Symlink, Unlink};
pub use global::{Init, Statfs};
pub use inode::{Bmap, Forget, Getattr};
pub use open::{Access, Create, Open, Opendir, Release, Releasedir};
pub use rw::{Flush, Fsync, Fsyncdir, Read, Readlink, Write};
pub use xattr::{Getxattr, Listxattr, Removexattr, Setxattr};
mod dir;
mod entry;
mod global;
mod inode;
mod open;
mod rw;
mod xattr;
pub(crate) use global::InitState;
pub trait FromRequest<'o, O: Operation<'o>> {
//TODO: Shouldn't be public
fn from_request(request: &Request<'o, O>) -> Self;
}
pub enum Any {}
impl Sealed for Any {}
impl<'o> Operation<'o> for Any {
type RequestBody = ();
type ReplyState = ();
}
impl<'o, O: Operation<'o>> FromRequest<'o, O> for () {
fn from_request(_request: &Request<'o, O>) -> Self {}
}
impl<'o, O: Operation<'o>> Reply<'o, O> {
fn empty(self) -> Done<'o> {
self.chain(OutputChain::empty())
}
fn single<P: Pod>(self, single: &P) -> Done<'o> {
self.chain(OutputChain::tail(&[bytes_of(single)]))
}
fn inner(self, deref: impl FnOnce(&Self) -> &[u8]) -> Done<'o> {
let result = self
.session
.ok(self.unique, OutputChain::tail(&[deref(&self)]));
self.finish(result)
}
fn chain(self, chain: OutputChain<'_>) -> Done<'o> {
let result = self.session.ok(self.unique, chain);
self.finish(result)
}
}
fn make_entry(
(Ino(ino), entry_ttl): (Ino, Ttl),
(attrs, attr_ttl): (proto::Attrs, Ttl),
) -> proto::EntryOut {
proto::EntryOut {
nodeid: ino,
generation: 0, //TODO
entry_valid: entry_ttl.seconds,
attr_valid: attr_ttl.seconds,
entry_valid_nsec: entry_ttl.nanoseconds,
attr_valid_nsec: attr_ttl.nanoseconds,
attr: attrs,
}
}
fn c_to_os(c_str: &CStr) -> &OsStr {
OsStr::from_bytes(c_str.to_bytes())
}
|
