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
|
use std::{
ffi::{CStr, OsStr},
os::unix::ffi::OsStrExt,
};
use crate::util::OutputChain;
use super::{private_trait::Sealed, Done, Operation, Reply, Request};
use bytemuck::{bytes_of, Pod};
mod dir;
mod entry;
mod global;
mod open;
mod rw;
mod xattr;
pub use dir::{BufferedReaddir, Lookup, Readdir};
pub use entry::{Forget, Getattr};
pub use global::{Init, Statfs};
pub use open::{Access, Open, Opendir, Release, Releasedir};
pub use rw::{Flush, Read, Readlink, Write};
pub use xattr::{Getxattr, Listxattr, Removexattr, Setxattr};
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 ReplyTail = ();
}
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 c_to_os(c_str: &CStr) -> &OsStr {
OsStr::from_bytes(c_str.to_bytes())
}
|
