summaryrefslogtreecommitdiff
path: root/src/ops/entry.rs
diff options
context:
space:
mode:
Diffstat (limited to '')
-rw-r--r--src/ops/entry.rs43
1 files changed, 41 insertions, 2 deletions
diff --git a/src/ops/entry.rs b/src/ops/entry.rs
index bcbe6b8..1af5483 100644
--- a/src/ops/entry.rs
+++ b/src/ops/entry.rs
@@ -6,12 +6,17 @@ use super::{
use crate::{io::Mode, private_trait::Sealed, proto, Ino, Operation, Request};
use std::ffi::{CStr, OsStr};
+pub enum Mknod {}
pub enum Mkdir {}
pub enum Unlink {}
pub enum Rmdir {}
pub enum Symlink {}
pub enum Link {}
+pub trait RequestDevice<'o>: Operation<'o> {
+ fn device(request: &Request<'o, Self>) -> u32;
+}
+
pub trait RequestTarget<'o>: Operation<'o> {
fn target<'a>(request: &'a Request<'o, Self>) -> &'a OsStr;
}
@@ -20,24 +25,30 @@ pub trait RequestLink<'o>: Operation<'o> {
fn source_ino(request: &Request<'o, Self>) -> Ino;
}
+impl Sealed for Mknod {}
impl Sealed for Mkdir {}
impl Sealed for Unlink {}
impl Sealed for Rmdir {}
impl Sealed for Symlink {}
impl Sealed for Link {}
+impl<'o> Operation<'o> for Mknod {
+ type RequestBody = (&'o proto::MknodIn, &'o CStr);
+ type ReplyState = ();
+}
+
impl<'o> Operation<'o> for Mkdir {
type RequestBody = (&'o proto::MkdirIn, &'o CStr);
type ReplyState = ();
}
impl<'o> Operation<'o> for Unlink {
- type RequestBody = &'o CStr; // name()
+ type RequestBody = &'o CStr;
type ReplyState = ();
}
impl<'o> Operation<'o> for Rmdir {
- type RequestBody = &'o CStr; // name()
+ type RequestBody = &'o CStr;
type ReplyState = ();
}
@@ -51,6 +62,34 @@ impl<'o> Operation<'o> for Link {
type ReplyState = ();
}
+impl<'o> RequestName<'o> for Mknod {
+ fn name<'a>(request: &'a Request<'o, Self>) -> &'a OsStr {
+ let (_header, name) = request.body;
+ c_to_os(name)
+ }
+}
+
+impl<'o> RequestMode<'o> for Mknod {
+ fn mode(request: &Request<'o, Self>) -> Mode {
+ let (header, _name) = request.body;
+ Mode::from_bits_truncate(header.mode)
+ }
+
+ fn umask(request: &Request<'o, Self>) -> Mode {
+ let (header, _name) = request.body;
+ Mode::from_bits_truncate(header.umask)
+ }
+}
+
+impl<'o> RequestDevice<'o> for Mknod {
+ fn device(request: &Request<'o, Self>) -> u32 {
+ let (header, _name) = request.body;
+ header.device
+ }
+}
+
+impl<'o> ReplyKnown<'o> for Mknod {}
+
impl<'o> RequestName<'o> for Mkdir {
fn name<'a>(request: &'a Request<'o, Self>) -> &'a OsStr {
let (_header, name) = request.body;