Skip to content
Snippets Groups Projects
Verified Commit 708cc1c5 authored by Jacob Lorentzon's avatar Jacob Lorentzon
Browse files

Use SYS_READ2 and SYS_WRITE2 for disk IO.

parent 8a31d1b6
No related branches found
No related tags found
No related merge requests found
use std::fs::{File, OpenOptions};
use std::io::{Read, Seek, SeekFrom, Write};
use std::path::Path;
use syscall::error::{Error, Result, EIO};
use syscall::error::{Result, Error, EIO};
#[cfg(target_os = "redox")]
use std::os::fd::AsRawFd;
use crate::disk::Disk;
use crate::BLOCK_SIZE;
macro_rules! try_disk {
($expr:expr) => {
match $expr {
Ok(val) => val,
pub struct DiskFile {
pub file: File,
}
trait ResultExt {
type T;
fn or_eio(self) -> Result<Self::T>;
}
impl<T> ResultExt for Result<T> {
type T = T;
fn or_eio(self) -> Result<Self::T> {
match self {
Ok(t) => Ok(t),
Err(err) => {
eprintln!("Disk I/O Error: {}", err);
return Err(Error::new(EIO));
eprintln!("RedoxFS: IO ERROR: {err}");
Err(Error::new(EIO))
}
}
};
}
}
pub struct DiskFile {
pub file: File,
impl<T> ResultExt for std::io::Result<T> {
type T = T;
fn or_eio(self) -> Result<Self::T> {
match self {
Ok(t) => Ok(t),
Err(err) => {
eprintln!("RedoxFS: IO ERROR: {err}");
Err(Error::new(EIO))
}
}
}
}
impl DiskFile {
pub fn open<P: AsRef<Path>>(path: P) -> Result<DiskFile> {
let file = try_disk!(OpenOptions::new().read(true).write(true).open(path));
pub fn open(path: impl AsRef<Path>) -> Result<DiskFile> {
let file = OpenOptions::new().read(true).write(true).open(path).or_eio()?;
Ok(DiskFile { file })
}
pub fn create<P: AsRef<Path>>(path: P, size: u64) -> Result<DiskFile> {
let file = try_disk!(OpenOptions::new()
pub fn create(path: impl AsRef<Path>, size: u64) -> Result<DiskFile> {
let file = OpenOptions::new()
.read(true)
.write(true)
.create(true)
.open(path));
try_disk!(file.set_len(size));
.open(path)
.or_eio()?;
file.set_len(size).or_eio()?;
Ok(DiskFile { file })
}
}
impl Disk for DiskFile {
unsafe fn read_at(&mut self, block: u64, buffer: &mut [u8]) -> Result<usize> {
try_disk!(self.file.seek(SeekFrom::Start(block * BLOCK_SIZE)));
let count = try_disk!(self.file.read(buffer));
Ok(count)
#[cfg(target_os = "redox")]
unsafe {
syscall::syscall5(syscall::SYS_READ2, self.file.as_raw_fd() as usize, buffer.as_mut_ptr() as usize, buffer.len(), (block * BLOCK_SIZE) as usize, 0)
.or_eio()
}
#[cfg(not(target_os = "redox"))]
{
self.file.seek(SeekFrom::Start(block * BLOCK_SIZE)).or_eio()?;
self.file.read(buffer).or_eio()
}
}
unsafe fn write_at(&mut self, block: u64, buffer: &[u8]) -> Result<usize> {
try_disk!(self.file.seek(SeekFrom::Start(block * BLOCK_SIZE)));
let count = try_disk!(self.file.write(buffer));
Ok(count)
#[cfg(target_os = "redox")]
unsafe {
syscall::syscall5(syscall::SYS_WRITE2, self.file.as_raw_fd() as usize, buffer.as_ptr() as usize, buffer.len(), (block * BLOCK_SIZE) as usize, 0)
.or_eio()
}
#[cfg(not(target_os = "redox"))]
{
self.file.seek(SeekFrom::Start(block * BLOCK_SIZE)).or_eio()?;
self.file.write(buffer).or_eio()
}
}
fn size(&mut self) -> Result<u64> {
let size = try_disk!(self.file.seek(SeekFrom::End(0)));
Ok(size)
self.file.seek(SeekFrom::End(0)).or_eio()
}
}
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment