Implement fsize+ftruncate, update, and rustfmt.

This commit is contained in:
4lDO2
2024-09-06 15:48:39 +02:00
parent b69453c97a
commit 286bd4a7d6
4 changed files with 39 additions and 28 deletions
+13 -8
View File
@@ -1,4 +1,4 @@
use redox_scheme::{RequestKind, SignalBehavior, Socket};
use redox_scheme::{RequestKind, SignalBehavior, Socket, V2};
use scheme::ZeroScheme;
@@ -21,26 +21,31 @@ fn main() {
Ty::Null => "null",
Ty::Zero => "zero",
};
let socket = Socket::create(name).expect("zerod: failed to create zero scheme");
let zero_scheme = ZeroScheme(ty);
let socket = Socket::<V2>::create(name).expect("zerod: failed to create zero scheme");
let mut zero_scheme = ZeroScheme(ty);
libredox::call::setrens(0, 0).expect("zerod: failed to enter null namespace");
daemon.ready().expect("zerod: failed to notify parent");
loop {
let Some(request) = socket.next_request(SignalBehavior::Restart).expect("zerod: failed to read events from zero scheme") else {
let Some(request) = socket
.next_request(SignalBehavior::Restart)
.expect("zerod: failed to read events from zero scheme")
else {
std::process::exit(0);
};
match request.kind() {
RequestKind::Call(request) => {
let response = request.handle_scheme(&zero_scheme);
let response = request.handle_scheme_mut(&mut zero_scheme);
socket.write_responses(&[response], SignalBehavior::Restart).expect("zerod: failed to write responses to zero scheme");
socket
.write_responses(&[response], SignalBehavior::Restart)
.expect("zerod: failed to write responses to zero scheme");
}
_ => (),
}
}
}).expect("zerod: failed to daemonize");
})
.expect("zerod: failed to daemonize");
}
+17 -11
View File
@@ -1,16 +1,16 @@
use redox_scheme::SchemeMut;
use syscall::{error::*, MODE_CHR};
use redox_scheme::Scheme;
use crate::Ty;
pub struct ZeroScheme(pub Ty);
impl Scheme for ZeroScheme {
fn open(&self, _path: &str, _flags: usize, _uid: u32, _gid: u32) -> Result<usize> {
impl SchemeMut for ZeroScheme {
fn open(&mut self, _path: &str, _flags: usize, _uid: u32, _gid: u32) -> Result<usize> {
Ok(0)
}
fn dup(&self, _file: usize, buf: &[u8]) -> Result<usize> {
fn dup(&mut self, _file: usize, buf: &[u8]) -> Result<usize> {
if !buf.is_empty() {
return Err(Error::new(EINVAL));
}
@@ -18,7 +18,7 @@ impl Scheme for ZeroScheme {
Ok(0)
}
fn read(&self, _file: usize, buf: &mut [u8]) -> Result<usize> {
fn read(&mut self, _file: usize, buf: &mut [u8], _offset: u64, _flags: u32) -> Result<usize> {
match self.0 {
Ty::Null => Ok(0),
Ty::Zero => {
@@ -28,15 +28,21 @@ impl Scheme for ZeroScheme {
}
}
fn write(&self, _file: usize, buffer: &[u8]) -> Result<usize> {
fn write(&mut self, _file: usize, buffer: &[u8], _offset: u64, _flags: u32) -> Result<usize> {
Ok(buffer.len())
}
fn fcntl(&self, _id: usize, _cmd: usize, _arg: usize) -> Result<usize> {
fn fcntl(&mut self, _id: usize, _cmd: usize, _arg: usize) -> Result<usize> {
Ok(0)
}
fn fsize(&mut self, _id: usize) -> Result<u64> {
Ok(0)
}
fn ftruncate(&mut self, _id: usize, _len: usize) -> Result<usize> {
Ok(0)
}
fn fpath(&self, _id: usize, buf: &mut [u8]) -> Result<usize> {
fn fpath(&mut self, _id: usize, buf: &mut [u8]) -> Result<usize> {
let scheme_path = b"zero:";
let size = std::cmp::min(buf.len(), scheme_path.len());
@@ -45,15 +51,15 @@ impl Scheme for ZeroScheme {
Ok(size)
}
fn fsync(&self, _file: usize) -> Result<usize> {
fn fsync(&mut self, _file: usize) -> Result<usize> {
Ok(0)
}
/// Close the file `number`
fn close(&self, _file: usize) -> Result<usize> {
fn close(&mut self, _file: usize) -> Result<usize> {
Ok(0)
}
fn fstat(&self, _: usize, stat: &mut syscall::Stat) -> Result<usize> {
fn fstat(&mut self, _: usize, stat: &mut syscall::Stat) -> Result<usize> {
stat.st_mode = 0o666 | MODE_CHR;
stat.st_size = 0;
stat.st_blocks = 0;