Merge remote-tracking branch 'upstream/master' into refactoring_error_handling_lightbeam
This commit is contained in:
20
.github/workflows/main.yml
vendored
20
.github/workflows/main.yml
vendored
@@ -82,9 +82,23 @@ jobs:
|
|||||||
working-directory: ./fuzz
|
working-directory: ./fuzz
|
||||||
# NB: the `-runs=0` means that libFuzzer won't generate new inputs, only run
|
# NB: the `-runs=0` means that libFuzzer won't generate new inputs, only run
|
||||||
# the seeds from the corpus.
|
# the seeds from the corpus.
|
||||||
- run: cargo fuzz run compile -- -runs=0
|
- run: cargo fuzz run compile --release --debug-assertions -- -runs=0
|
||||||
- run: cargo fuzz run instantiate -- -runs=0
|
- run: cargo fuzz run instantiate --release --debug-assertions -- -runs=0
|
||||||
- run: cargo fuzz run instantiate_translated -- -runs=0
|
- run: cargo fuzz run instantiate_translated --release --debug-assertions -- -runs=0
|
||||||
|
- run: cargo fuzz run api_calls --release --debug-assertions -- -runs=0
|
||||||
|
|
||||||
|
# Install wasm32-unknown-emscripten target, and ensure `crates/wasi-common`
|
||||||
|
# compiles to Emscripten.
|
||||||
|
emscripten:
|
||||||
|
name: Emscripten
|
||||||
|
runs-on: ubuntu-latest
|
||||||
|
steps:
|
||||||
|
- uses: actions/checkout@v1
|
||||||
|
with:
|
||||||
|
submodules: true
|
||||||
|
- uses: ./.github/actions/install-rust
|
||||||
|
- run: rustup target add wasm32-unknown-emscripten
|
||||||
|
- run: cargo build --target wasm32-unknown-emscripten -p wasi-common
|
||||||
|
|
||||||
# Perform all tests (debug mode) for `wasmtime`. This runs stable/beta/nightly
|
# Perform all tests (debug mode) for `wasmtime`. This runs stable/beta/nightly
|
||||||
# channels of Rust as well as macOS/Linux/Windows.
|
# channels of Rust as well as macOS/Linux/Windows.
|
||||||
|
|||||||
@@ -9,7 +9,84 @@ use wasmtime_environ::ir;
|
|||||||
use wasmtime_jit::InstanceHandle;
|
use wasmtime_jit::InstanceHandle;
|
||||||
use wasmtime_runtime::Export;
|
use wasmtime_runtime::Export;
|
||||||
|
|
||||||
|
/// A trait representing a function that can be imported and called from inside
|
||||||
|
/// WebAssembly.
|
||||||
|
/// # Example
|
||||||
|
/// ```
|
||||||
|
/// use wasmtime::{HostRef, Val};
|
||||||
|
///
|
||||||
|
/// struct TimesTwo;
|
||||||
|
///
|
||||||
|
/// impl wasmtime::Callable for TimesTwo {
|
||||||
|
/// fn call(&self, params: &[Val], results: &mut [Val]) -> Result<(), HostRef<wasmtime::Trap>> {
|
||||||
|
/// let mut value = params[0].unwrap_i32();
|
||||||
|
/// value *= 2;
|
||||||
|
/// results[0] = value.into();
|
||||||
|
///
|
||||||
|
/// Ok(())
|
||||||
|
/// }
|
||||||
|
/// }
|
||||||
|
///
|
||||||
|
/// # fn main () -> Result<(), Box<dyn std::error::Error>> {
|
||||||
|
/// // Simple module that imports our host function ("times_two") and re-exports
|
||||||
|
/// // it as "run".
|
||||||
|
/// let binary = wat::parse_str(r#"
|
||||||
|
/// (module
|
||||||
|
/// (func $times_two (import "" "times_two") (param i32) (result i32))
|
||||||
|
/// (func
|
||||||
|
/// (export "run")
|
||||||
|
/// (param i32)
|
||||||
|
/// (result i32)
|
||||||
|
/// (local.get 0)
|
||||||
|
/// (call $times_two))
|
||||||
|
/// )
|
||||||
|
/// "#)?;
|
||||||
|
///
|
||||||
|
/// // Initialise environment and our module.
|
||||||
|
/// let engine = HostRef::new(wasmtime::Engine::default());
|
||||||
|
/// let store = HostRef::new(wasmtime::Store::new(&engine));
|
||||||
|
/// let module = HostRef::new(wasmtime::Module::new(&store, &binary)?);
|
||||||
|
///
|
||||||
|
/// // Define the type of the function we're going to call.
|
||||||
|
/// let times_two_type = wasmtime::FuncType::new(
|
||||||
|
/// // Parameters
|
||||||
|
/// Box::new([wasmtime::ValType::I32]),
|
||||||
|
/// // Results
|
||||||
|
/// Box::new([wasmtime::ValType::I32])
|
||||||
|
/// );
|
||||||
|
///
|
||||||
|
/// // Build a reference to the "times_two" function that can be used.
|
||||||
|
/// let times_two_function = HostRef::new(
|
||||||
|
/// wasmtime::Func::new(&store, times_two_type, std::rc::Rc::new(TimesTwo))
|
||||||
|
/// );
|
||||||
|
///
|
||||||
|
/// // Create module instance that imports our function
|
||||||
|
/// let instance = wasmtime::Instance::new(
|
||||||
|
/// &store,
|
||||||
|
/// &module,
|
||||||
|
/// &[times_two_function.into()]
|
||||||
|
/// )?;
|
||||||
|
///
|
||||||
|
/// // Get "run" function from the exports.
|
||||||
|
/// let run_function = instance.exports()[0].func().unwrap();
|
||||||
|
///
|
||||||
|
/// // Borrow and call "run". Returning any error message from Wasm as a string.
|
||||||
|
/// let original = 5i32;
|
||||||
|
/// let results = run_function
|
||||||
|
/// .borrow()
|
||||||
|
/// .call(&[original.into()])
|
||||||
|
/// .map_err(|trap| trap.borrow().to_string())?;
|
||||||
|
///
|
||||||
|
/// // Compare that the results returned matches what we expect.
|
||||||
|
/// assert_eq!(original * 2, results[0].unwrap_i32());
|
||||||
|
/// # Ok(())
|
||||||
|
/// # }
|
||||||
|
/// ```
|
||||||
pub trait Callable {
|
pub trait Callable {
|
||||||
|
/// What is called when the function is invoked in WebAssembly.
|
||||||
|
/// `params` is an immutable list of parameters provided to the function.
|
||||||
|
/// `results` is mutable list of results to be potentially set by your
|
||||||
|
/// function. Produces a `Trap` if the function encounters any errors.
|
||||||
fn call(&self, params: &[Val], results: &mut [Val]) -> Result<(), HostRef<Trap>>;
|
fn call(&self, params: &[Val], results: &mut [Val]) -> Result<(), HostRef<Trap>>;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -46,14 +46,19 @@ impl Drop for AnyAndHostInfo {
|
|||||||
#[derive(Clone)]
|
#[derive(Clone)]
|
||||||
pub struct OtherRef(Rc<RefCell<AnyAndHostInfo>>);
|
pub struct OtherRef(Rc<RefCell<AnyAndHostInfo>>);
|
||||||
|
|
||||||
|
/// Represents an opaque reference to any data within WebAssembly.
|
||||||
#[derive(Clone)]
|
#[derive(Clone)]
|
||||||
pub enum AnyRef {
|
pub enum AnyRef {
|
||||||
|
/// A reference to no data.
|
||||||
Null,
|
Null,
|
||||||
|
/// A reference to data stored internally in `wasmtime`.
|
||||||
Ref(InternalRef),
|
Ref(InternalRef),
|
||||||
|
/// A reference to data located outside of `wasmtime`.
|
||||||
Other(OtherRef),
|
Other(OtherRef),
|
||||||
}
|
}
|
||||||
|
|
||||||
impl AnyRef {
|
impl AnyRef {
|
||||||
|
/// Creates a new instance of `AnyRef` from `Box<dyn Any>`.
|
||||||
pub fn new(data: Box<dyn Any>) -> Self {
|
pub fn new(data: Box<dyn Any>) -> Self {
|
||||||
let info = AnyAndHostInfo {
|
let info = AnyAndHostInfo {
|
||||||
any: data,
|
any: data,
|
||||||
@@ -62,10 +67,14 @@ impl AnyRef {
|
|||||||
AnyRef::Other(OtherRef(Rc::new(RefCell::new(info))))
|
AnyRef::Other(OtherRef(Rc::new(RefCell::new(info))))
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// Creates a `Null` reference.
|
||||||
pub fn null() -> Self {
|
pub fn null() -> Self {
|
||||||
AnyRef::Null
|
AnyRef::Null
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// Returns the data stored in the reference if available.
|
||||||
|
/// # Panics
|
||||||
|
/// Panics if the variant isn't `AnyRef::Other`.
|
||||||
pub fn data(&self) -> cell::Ref<Box<dyn Any>> {
|
pub fn data(&self) -> cell::Ref<Box<dyn Any>> {
|
||||||
match self {
|
match self {
|
||||||
AnyRef::Other(OtherRef(r)) => cell::Ref::map(r.borrow(), |r| &r.any),
|
AnyRef::Other(OtherRef(r)) => cell::Ref::map(r.borrow(), |r| &r.any),
|
||||||
@@ -73,6 +82,8 @@ impl AnyRef {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// Returns true if the two `AnyRef<T>`'s point to the same value (not just
|
||||||
|
/// values that compare as equal).
|
||||||
pub fn ptr_eq(&self, other: &AnyRef) -> bool {
|
pub fn ptr_eq(&self, other: &AnyRef) -> bool {
|
||||||
match (self, other) {
|
match (self, other) {
|
||||||
(AnyRef::Null, AnyRef::Null) => true,
|
(AnyRef::Null, AnyRef::Null) => true,
|
||||||
@@ -84,6 +95,9 @@ impl AnyRef {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// Returns a mutable reference to the host information if available.
|
||||||
|
/// # Panics
|
||||||
|
/// Panics if `AnyRef` is already borrowed or `AnyRef` is `Null`.
|
||||||
pub fn host_info(&self) -> Option<cell::RefMut<Box<dyn HostInfo>>> {
|
pub fn host_info(&self) -> Option<cell::RefMut<Box<dyn HostInfo>>> {
|
||||||
match self {
|
match self {
|
||||||
AnyRef::Null => panic!("null"),
|
AnyRef::Null => panic!("null"),
|
||||||
@@ -98,6 +112,9 @@ impl AnyRef {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// Sets the host information for an `AnyRef`.
|
||||||
|
/// # Panics
|
||||||
|
/// Panics if `AnyRef` is already borrowed or `AnyRef` is `Null`.
|
||||||
pub fn set_host_info(&self, info: Option<Box<dyn HostInfo>>) {
|
pub fn set_host_info(&self, info: Option<Box<dyn HostInfo>>) {
|
||||||
match self {
|
match self {
|
||||||
AnyRef::Null => panic!("null"),
|
AnyRef::Null => panic!("null"),
|
||||||
@@ -133,9 +150,11 @@ impl<T> Drop for ContentBox<T> {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// Represents a piece of data located in the host environment.
|
||||||
pub struct HostRef<T>(Rc<RefCell<ContentBox<T>>>);
|
pub struct HostRef<T>(Rc<RefCell<ContentBox<T>>>);
|
||||||
|
|
||||||
impl<T: 'static> HostRef<T> {
|
impl<T: 'static> HostRef<T> {
|
||||||
|
/// Creates a new `HostRef<T>` from `T`.
|
||||||
pub fn new(item: T) -> HostRef<T> {
|
pub fn new(item: T) -> HostRef<T> {
|
||||||
let anyref_data: Weak<HostRef<T>> = Weak::new();
|
let anyref_data: Weak<HostRef<T>> = Weak::new();
|
||||||
let content = ContentBox {
|
let content = ContentBox {
|
||||||
@@ -146,18 +165,30 @@ impl<T: 'static> HostRef<T> {
|
|||||||
HostRef(Rc::new(RefCell::new(content)))
|
HostRef(Rc::new(RefCell::new(content)))
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// Immutably borrows the wrapped data.
|
||||||
|
/// # Panics
|
||||||
|
/// Panics if the value is currently mutably borrowed.
|
||||||
pub fn borrow(&self) -> cell::Ref<T> {
|
pub fn borrow(&self) -> cell::Ref<T> {
|
||||||
cell::Ref::map(self.0.borrow(), |b| &b.content)
|
cell::Ref::map(self.0.borrow(), |b| &b.content)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// Mutably borrows the wrapped data.
|
||||||
|
/// # Panics
|
||||||
|
/// Panics if the `HostRef<T>` is already borrowed.
|
||||||
pub fn borrow_mut(&self) -> cell::RefMut<T> {
|
pub fn borrow_mut(&self) -> cell::RefMut<T> {
|
||||||
cell::RefMut::map(self.0.borrow_mut(), |b| &mut b.content)
|
cell::RefMut::map(self.0.borrow_mut(), |b| &mut b.content)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// Returns true if the two `HostRef<T>`'s point to the same value (not just
|
||||||
|
/// values that compare as equal).
|
||||||
pub fn ptr_eq(&self, other: &HostRef<T>) -> bool {
|
pub fn ptr_eq(&self, other: &HostRef<T>) -> bool {
|
||||||
Rc::ptr_eq(&self.0, &other.0)
|
Rc::ptr_eq(&self.0, &other.0)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// Returns an opaque reference to the wrapped data in the form of
|
||||||
|
/// an `AnyRef`.
|
||||||
|
/// # Panics
|
||||||
|
/// Panics if `HostRef<T>` is already mutably borrowed.
|
||||||
pub fn anyref(&self) -> AnyRef {
|
pub fn anyref(&self) -> AnyRef {
|
||||||
let r = self.0.borrow_mut().anyref_data.upgrade();
|
let r = self.0.borrow_mut().anyref_data.upgrade();
|
||||||
if let Some(r) = r {
|
if let Some(r) = r {
|
||||||
|
|||||||
@@ -1,5 +1,7 @@
|
|||||||
use thiserror::Error;
|
use thiserror::Error;
|
||||||
|
|
||||||
|
/// A struct representing an aborted instruction execution, with a message
|
||||||
|
/// indicating the cause.
|
||||||
#[derive(Error, Debug)]
|
#[derive(Error, Debug)]
|
||||||
#[error("Wasm trap: {message}")]
|
#[error("Wasm trap: {message}")]
|
||||||
pub struct Trap {
|
pub struct Trap {
|
||||||
@@ -7,14 +9,25 @@ pub struct Trap {
|
|||||||
}
|
}
|
||||||
|
|
||||||
impl Trap {
|
impl Trap {
|
||||||
pub fn new(message: String) -> Trap {
|
/// Creates a new `Trap` with `message`.
|
||||||
Trap { message }
|
/// # Example
|
||||||
|
/// ```
|
||||||
|
/// let trap = wasmtime::Trap::new("unexpected error");
|
||||||
|
/// assert_eq!("unexpected error", trap.message());
|
||||||
|
/// ```
|
||||||
|
pub fn new<I: Into<String>>(message: I) -> Trap {
|
||||||
|
Self {
|
||||||
|
message: message.into(),
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// Create a `Trap` without defining a message for the trap. Mostly useful
|
||||||
|
/// for prototypes and tests.
|
||||||
pub fn fake() -> Trap {
|
pub fn fake() -> Trap {
|
||||||
Trap::new("TODO trap".to_string())
|
Self::new("TODO trap")
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// Returns a reference the `message` stored in `Trap`.
|
||||||
pub fn message(&self) -> &str {
|
pub fn message(&self) -> &str {
|
||||||
&self.message
|
&self.message
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -39,7 +39,7 @@ impl Limits {
|
|||||||
self.min
|
self.min
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Returs the maximum amount for these limits, if specified.
|
/// Returns the maximum amount for these limits, if specified.
|
||||||
pub fn max(&self) -> Option<u32> {
|
pub fn max(&self) -> Option<u32> {
|
||||||
self.max
|
self.max
|
||||||
}
|
}
|
||||||
@@ -47,18 +47,28 @@ impl Limits {
|
|||||||
|
|
||||||
// Value Types
|
// Value Types
|
||||||
|
|
||||||
|
/// A list of all possible value types in WebAssembly.
|
||||||
#[derive(Debug, Clone, Eq, PartialEq)]
|
#[derive(Debug, Clone, Eq, PartialEq)]
|
||||||
pub enum ValType {
|
pub enum ValType {
|
||||||
|
/// Signed 32 bit integer.
|
||||||
I32,
|
I32,
|
||||||
|
/// Signed 64 bit integer.
|
||||||
I64,
|
I64,
|
||||||
|
/// Floating point 32 bit integer.
|
||||||
F32,
|
F32,
|
||||||
|
/// Floating point 64 bit integer.
|
||||||
F64,
|
F64,
|
||||||
|
/// A 128 bit number.
|
||||||
V128,
|
V128,
|
||||||
|
/// A reference to opaque data in the Wasm instance.
|
||||||
AnyRef, /* = 128 */
|
AnyRef, /* = 128 */
|
||||||
|
/// A reference to a Wasm function.
|
||||||
FuncRef,
|
FuncRef,
|
||||||
}
|
}
|
||||||
|
|
||||||
impl ValType {
|
impl ValType {
|
||||||
|
/// Returns true if `ValType` matches any of the numeric types. (e.g. `I32`,
|
||||||
|
/// `I64`, `F32`, `F64`).
|
||||||
pub fn is_num(&self) -> bool {
|
pub fn is_num(&self) -> bool {
|
||||||
match self {
|
match self {
|
||||||
ValType::I32 | ValType::I64 | ValType::F32 | ValType::F64 => true,
|
ValType::I32 | ValType::I64 | ValType::F32 | ValType::F64 => true,
|
||||||
@@ -66,6 +76,7 @@ impl ValType {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// Returns true if `ValType` matches either of the reference types.
|
||||||
pub fn is_ref(&self) -> bool {
|
pub fn is_ref(&self) -> bool {
|
||||||
match self {
|
match self {
|
||||||
ValType::AnyRef | ValType::FuncRef => true,
|
ValType::AnyRef | ValType::FuncRef => true,
|
||||||
@@ -113,8 +124,8 @@ pub enum ExternType {
|
|||||||
|
|
||||||
macro_rules! accessors {
|
macro_rules! accessors {
|
||||||
($(($variant:ident($ty:ty) $get:ident $unwrap:ident))*) => ($(
|
($(($variant:ident($ty:ty) $get:ident $unwrap:ident))*) => ($(
|
||||||
/// Attempt to return the underlying type of this external type,
|
/// Attempt to return the underlying type of this external type,
|
||||||
/// returning `None` if it is a different type.
|
/// returning `None` if it is a different type.
|
||||||
pub fn $get(&self) -> Option<&$ty> {
|
pub fn $get(&self) -> Option<&$ty> {
|
||||||
if let ExternType::$variant(e) = self {
|
if let ExternType::$variant(e) = self {
|
||||||
Some(e)
|
Some(e)
|
||||||
@@ -123,7 +134,7 @@ macro_rules! accessors {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Returns the underlying descriptor of this [`ExternType`], panicking
|
/// Returns the underlying descriptor of this [`ExternType`], panicking
|
||||||
/// if it is a different type.
|
/// if it is a different type.
|
||||||
///
|
///
|
||||||
/// # Panics
|
/// # Panics
|
||||||
|
|||||||
@@ -8,7 +8,7 @@ fn test_trap_return() -> Result<(), String> {
|
|||||||
|
|
||||||
impl Callable for HelloCallback {
|
impl Callable for HelloCallback {
|
||||||
fn call(&self, _params: &[Val], _results: &mut [Val]) -> Result<(), HostRef<Trap>> {
|
fn call(&self, _params: &[Val], _results: &mut [Val]) -> Result<(), HostRef<Trap>> {
|
||||||
Err(HostRef::new(Trap::new("test 123".into())))
|
Err(HostRef::new(Trap::new("test 123")))
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -8,15 +8,28 @@
|
|||||||
//! wrapper over an external tool, such that the wrapper implements the
|
//! wrapper over an external tool, such that the wrapper implements the
|
||||||
//! `Arbitrary` trait for the wrapped external tool.
|
//! `Arbitrary` trait for the wrapped external tool.
|
||||||
|
|
||||||
|
pub mod api;
|
||||||
|
|
||||||
use arbitrary::{Arbitrary, Unstructured};
|
use arbitrary::{Arbitrary, Unstructured};
|
||||||
|
use std::fmt;
|
||||||
|
|
||||||
/// A Wasm test case generator that is powered by Binaryen's `wasm-opt -ttf`.
|
/// A Wasm test case generator that is powered by Binaryen's `wasm-opt -ttf`.
|
||||||
#[derive(Debug)]
|
#[derive(Clone)]
|
||||||
pub struct WasmOptTtf {
|
pub struct WasmOptTtf {
|
||||||
/// The raw, encoded Wasm bytes.
|
/// The raw, encoded Wasm bytes.
|
||||||
pub wasm: Vec<u8>,
|
pub wasm: Vec<u8>,
|
||||||
}
|
}
|
||||||
|
|
||||||
|
impl fmt::Debug for WasmOptTtf {
|
||||||
|
fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
|
||||||
|
write!(
|
||||||
|
f,
|
||||||
|
"WasmOptTtf {{ wasm: wat::parse_str(r###\"\n{}\n\"###).unwrap() }}",
|
||||||
|
wasmprinter::print_bytes(&self.wasm).expect("valid wasm should always disassemble")
|
||||||
|
)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
impl Arbitrary for WasmOptTtf {
|
impl Arbitrary for WasmOptTtf {
|
||||||
fn arbitrary<U>(input: &mut U) -> Result<Self, U::Error>
|
fn arbitrary<U>(input: &mut U) -> Result<Self, U::Error>
|
||||||
where
|
where
|
||||||
|
|||||||
182
crates/fuzzing/src/generators/api.rs
Normal file
182
crates/fuzzing/src/generators/api.rs
Normal file
@@ -0,0 +1,182 @@
|
|||||||
|
//! Generating sequences of Wasmtime API calls.
|
||||||
|
//!
|
||||||
|
//! We only generate *valid* sequences of API calls. To do this, we keep track
|
||||||
|
//! of what objects we've already created in earlier API calls via the `Scope`
|
||||||
|
//! struct.
|
||||||
|
//!
|
||||||
|
//! To generate even-more-pathological sequences of API calls, we use [swarm
|
||||||
|
//! testing]:
|
||||||
|
//!
|
||||||
|
//! > In swarm testing, the usual practice of potentially including all features
|
||||||
|
//! > in every test case is abandoned. Rather, a large “swarm” of randomly
|
||||||
|
//! > generated configurations, each of which omits some features, is used, with
|
||||||
|
//! > configurations receiving equal resources.
|
||||||
|
//!
|
||||||
|
//! [swarm testing]: https://www.cs.utah.edu/~regehr/papers/swarm12.pdf
|
||||||
|
|
||||||
|
use arbitrary::{Arbitrary, Unstructured};
|
||||||
|
use std::collections::HashSet;
|
||||||
|
|
||||||
|
struct Swarm {
|
||||||
|
config_debug_info: bool,
|
||||||
|
module_new: bool,
|
||||||
|
module_drop: bool,
|
||||||
|
instance_new: bool,
|
||||||
|
instance_drop: bool,
|
||||||
|
call_exported_func: bool,
|
||||||
|
}
|
||||||
|
|
||||||
|
impl Arbitrary for Swarm {
|
||||||
|
fn arbitrary<U>(input: &mut U) -> Result<Self, U::Error>
|
||||||
|
where
|
||||||
|
U: Unstructured + ?Sized,
|
||||||
|
{
|
||||||
|
Ok(Swarm {
|
||||||
|
config_debug_info: bool::arbitrary(input)?,
|
||||||
|
module_new: bool::arbitrary(input)?,
|
||||||
|
module_drop: bool::arbitrary(input)?,
|
||||||
|
instance_new: bool::arbitrary(input)?,
|
||||||
|
instance_drop: bool::arbitrary(input)?,
|
||||||
|
call_exported_func: bool::arbitrary(input)?,
|
||||||
|
})
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// A call to one of Wasmtime's public APIs.
|
||||||
|
#[derive(Clone, Debug)]
|
||||||
|
#[allow(missing_docs)]
|
||||||
|
pub enum ApiCall {
|
||||||
|
ConfigNew,
|
||||||
|
ConfigDebugInfo(bool),
|
||||||
|
EngineNew,
|
||||||
|
StoreNew,
|
||||||
|
ModuleNew { id: usize, wasm: super::WasmOptTtf },
|
||||||
|
ModuleDrop { id: usize },
|
||||||
|
InstanceNew { id: usize, module: usize },
|
||||||
|
InstanceDrop { id: usize },
|
||||||
|
CallExportedFunc { instance: usize, nth: usize },
|
||||||
|
}
|
||||||
|
use ApiCall::*;
|
||||||
|
|
||||||
|
#[derive(Default)]
|
||||||
|
struct Scope {
|
||||||
|
id_counter: usize,
|
||||||
|
modules: HashSet<usize>,
|
||||||
|
instances: HashSet<usize>,
|
||||||
|
}
|
||||||
|
|
||||||
|
impl Scope {
|
||||||
|
fn next_id(&mut self) -> usize {
|
||||||
|
let id = self.id_counter;
|
||||||
|
self.id_counter = id + 1;
|
||||||
|
id
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// A sequence of API calls.
|
||||||
|
#[derive(Debug)]
|
||||||
|
pub struct ApiCalls {
|
||||||
|
/// The API calls.
|
||||||
|
pub calls: Vec<ApiCall>,
|
||||||
|
}
|
||||||
|
|
||||||
|
impl Arbitrary for ApiCalls {
|
||||||
|
fn arbitrary<U>(input: &mut U) -> Result<Self, U::Error>
|
||||||
|
where
|
||||||
|
U: Unstructured + ?Sized,
|
||||||
|
{
|
||||||
|
let swarm = Swarm::arbitrary(input)?;
|
||||||
|
let mut calls = vec![];
|
||||||
|
|
||||||
|
arbitrary_config(input, &swarm, &mut calls)?;
|
||||||
|
calls.push(EngineNew);
|
||||||
|
calls.push(StoreNew);
|
||||||
|
|
||||||
|
let mut scope = Scope::default();
|
||||||
|
|
||||||
|
for _ in 0..input.container_size()? {
|
||||||
|
let mut choices: Vec<fn(_, &mut Scope) -> Result<ApiCall, U::Error>> = vec![];
|
||||||
|
|
||||||
|
if swarm.module_new {
|
||||||
|
choices.push(|input, scope| {
|
||||||
|
let id = scope.next_id();
|
||||||
|
scope.modules.insert(id);
|
||||||
|
let wasm = super::WasmOptTtf::arbitrary(input)?;
|
||||||
|
Ok(ModuleNew { id, wasm })
|
||||||
|
});
|
||||||
|
}
|
||||||
|
if swarm.module_drop && !scope.modules.is_empty() {
|
||||||
|
choices.push(|input, scope| {
|
||||||
|
let modules: Vec<_> = scope.modules.iter().cloned().collect();
|
||||||
|
let id = arbitrary_choice(input, &modules)?.cloned().unwrap();
|
||||||
|
scope.modules.remove(&id);
|
||||||
|
Ok(ModuleDrop { id })
|
||||||
|
});
|
||||||
|
}
|
||||||
|
if swarm.instance_new && !scope.modules.is_empty() {
|
||||||
|
choices.push(|input, scope| {
|
||||||
|
let modules: Vec<_> = scope.modules.iter().cloned().collect();
|
||||||
|
let module = arbitrary_choice(input, &modules)?.cloned().unwrap();
|
||||||
|
let id = scope.next_id();
|
||||||
|
scope.instances.insert(id);
|
||||||
|
Ok(InstanceNew { id, module })
|
||||||
|
});
|
||||||
|
}
|
||||||
|
if swarm.instance_drop && !scope.instances.is_empty() {
|
||||||
|
choices.push(|input, scope| {
|
||||||
|
let instances: Vec<_> = scope.instances.iter().cloned().collect();
|
||||||
|
let id = arbitrary_choice(input, &instances)?.cloned().unwrap();
|
||||||
|
scope.instances.remove(&id);
|
||||||
|
Ok(InstanceDrop { id })
|
||||||
|
});
|
||||||
|
}
|
||||||
|
if swarm.call_exported_func && !scope.instances.is_empty() {
|
||||||
|
choices.push(|input, scope| {
|
||||||
|
let instances: Vec<_> = scope.instances.iter().cloned().collect();
|
||||||
|
let instance = arbitrary_choice(input, &instances)?.cloned().unwrap();
|
||||||
|
let nth = usize::arbitrary(input)?;
|
||||||
|
Ok(CallExportedFunc { instance, nth })
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
if let Some(c) = arbitrary_choice(input, &choices)? {
|
||||||
|
calls.push(c(input, &mut scope)?);
|
||||||
|
} else {
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
Ok(ApiCalls { calls })
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn arbitrary_choice<'a, T, U>(input: &mut U, choices: &'a [T]) -> Result<Option<&'a T>, U::Error>
|
||||||
|
where
|
||||||
|
U: Unstructured + ?Sized,
|
||||||
|
{
|
||||||
|
if choices.is_empty() {
|
||||||
|
Ok(None)
|
||||||
|
} else {
|
||||||
|
let i = usize::arbitrary(input)? % choices.len();
|
||||||
|
Ok(Some(&choices[i]))
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
fn arbitrary_config<U>(
|
||||||
|
input: &mut U,
|
||||||
|
swarm: &Swarm,
|
||||||
|
calls: &mut Vec<ApiCall>,
|
||||||
|
) -> Result<(), U::Error>
|
||||||
|
where
|
||||||
|
U: Unstructured + ?Sized,
|
||||||
|
{
|
||||||
|
calls.push(ConfigNew);
|
||||||
|
|
||||||
|
if swarm.config_debug_info && bool::arbitrary(input)? {
|
||||||
|
calls.push(ConfigDebugInfo(bool::arbitrary(input)?));
|
||||||
|
}
|
||||||
|
|
||||||
|
// TODO: flags, features, and compilation strategy.
|
||||||
|
|
||||||
|
Ok(())
|
||||||
|
}
|
||||||
@@ -107,8 +107,12 @@ fn my_fuzzing_regression_test() {{
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
fn scratch_dir() -> PathBuf {
|
pub(crate) fn scratch_dir() -> PathBuf {
|
||||||
let dir = Path::new(env!("CARGO_MANIFEST_DIR"))
|
let dir = Path::new(env!("CARGO_MANIFEST_DIR"))
|
||||||
|
// Pop "fuzzing".
|
||||||
|
.join("..")
|
||||||
|
// Pop "crates".
|
||||||
|
.join("..")
|
||||||
.join("target")
|
.join("target")
|
||||||
.join("scratch");
|
.join("scratch");
|
||||||
|
|
||||||
|
|||||||
@@ -12,11 +12,11 @@
|
|||||||
|
|
||||||
pub mod dummy;
|
pub mod dummy;
|
||||||
|
|
||||||
use dummy::dummy_imports;
|
use dummy::{dummy_imports, dummy_value};
|
||||||
use std::cell::RefCell;
|
use std::cell::RefCell;
|
||||||
use std::collections::HashMap;
|
use std::collections::HashMap;
|
||||||
use std::rc::Rc;
|
use std::rc::Rc;
|
||||||
use wasmtime::{Config, Engine, HostRef, Instance, Module, Store};
|
use wasmtime::*;
|
||||||
use wasmtime_environ::{isa, settings};
|
use wasmtime_environ::{isa, settings};
|
||||||
use wasmtime_jit::{native, CompilationStrategy, CompiledModule, Compiler, NullResolver};
|
use wasmtime_jit::{native, CompilationStrategy, CompiledModule, Compiler, NullResolver};
|
||||||
|
|
||||||
@@ -83,3 +83,127 @@ pub fn compile(wasm: &[u8], compilation_strategy: CompilationStrategy) {
|
|||||||
let global_exports = Rc::new(RefCell::new(HashMap::new()));
|
let global_exports = Rc::new(RefCell::new(HashMap::new()));
|
||||||
let _ = CompiledModule::new(&mut compiler, wasm, &mut resolver, global_exports, false);
|
let _ = CompiledModule::new(&mut compiler, wasm, &mut resolver, global_exports, false);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// Invoke the given API calls.
|
||||||
|
pub fn make_api_calls(api: crate::generators::api::ApiCalls) {
|
||||||
|
use crate::generators::api::ApiCall;
|
||||||
|
|
||||||
|
let mut config: Option<Config> = None;
|
||||||
|
let mut engine: Option<HostRef<Engine>> = None;
|
||||||
|
let mut store: Option<HostRef<Store>> = None;
|
||||||
|
let mut modules: HashMap<usize, HostRef<Module>> = Default::default();
|
||||||
|
let mut instances: HashMap<usize, HostRef<Instance>> = Default::default();
|
||||||
|
|
||||||
|
for call in api.calls {
|
||||||
|
match call {
|
||||||
|
ApiCall::ConfigNew => {
|
||||||
|
assert!(config.is_none());
|
||||||
|
config = Some(Config::new());
|
||||||
|
}
|
||||||
|
|
||||||
|
ApiCall::ConfigDebugInfo(b) => {
|
||||||
|
config.as_mut().unwrap().debug_info(b);
|
||||||
|
}
|
||||||
|
|
||||||
|
ApiCall::EngineNew => {
|
||||||
|
assert!(engine.is_none());
|
||||||
|
engine = Some(HostRef::new(Engine::new(config.as_ref().unwrap())));
|
||||||
|
}
|
||||||
|
|
||||||
|
ApiCall::StoreNew => {
|
||||||
|
assert!(store.is_none());
|
||||||
|
store = Some(HostRef::new(Store::new(engine.as_ref().unwrap())));
|
||||||
|
}
|
||||||
|
|
||||||
|
ApiCall::ModuleNew { id, wasm } => {
|
||||||
|
let module = HostRef::new(match Module::new(store.as_ref().unwrap(), &wasm.wasm) {
|
||||||
|
Ok(m) => m,
|
||||||
|
Err(_) => continue,
|
||||||
|
});
|
||||||
|
let old = modules.insert(id, module);
|
||||||
|
assert!(old.is_none());
|
||||||
|
}
|
||||||
|
|
||||||
|
ApiCall::ModuleDrop { id } => {
|
||||||
|
drop(modules.remove(&id));
|
||||||
|
}
|
||||||
|
|
||||||
|
ApiCall::InstanceNew { id, module } => {
|
||||||
|
let module = match modules.get(&module) {
|
||||||
|
Some(m) => m,
|
||||||
|
None => continue,
|
||||||
|
};
|
||||||
|
|
||||||
|
let imports = {
|
||||||
|
let module = module.borrow();
|
||||||
|
match dummy_imports(store.as_ref().unwrap(), module.imports()) {
|
||||||
|
Ok(imps) => imps,
|
||||||
|
Err(_) => {
|
||||||
|
// There are some value types that we can't synthesize a
|
||||||
|
// dummy value for (e.g. anyrefs) and for modules that
|
||||||
|
// import things of these types we skip instantiation.
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
// Don't unwrap this: there can be instantiation-/link-time errors that
|
||||||
|
// aren't caught during validation or compilation. For example, an imported
|
||||||
|
// table might not have room for an element segment that we want to
|
||||||
|
// initialize into it.
|
||||||
|
if let Ok(instance) = Instance::new(store.as_ref().unwrap(), &module, &imports) {
|
||||||
|
instances.insert(id, HostRef::new(instance));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
ApiCall::InstanceDrop { id } => {
|
||||||
|
drop(instances.remove(&id));
|
||||||
|
}
|
||||||
|
|
||||||
|
ApiCall::CallExportedFunc { instance, nth } => {
|
||||||
|
let instance = match instances.get(&instance) {
|
||||||
|
Some(i) => i,
|
||||||
|
None => {
|
||||||
|
// Note that we aren't guaranteed to instantiate valid
|
||||||
|
// modules, see comments in `InstanceNew` for details on
|
||||||
|
// that. But the API call generator can't know if
|
||||||
|
// instantiation failed, so we might not actually have
|
||||||
|
// this instance. When that's the case, just skip the
|
||||||
|
// API call and keep going.
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
|
let funcs = {
|
||||||
|
let instance = instance.borrow();
|
||||||
|
instance
|
||||||
|
.exports()
|
||||||
|
.iter()
|
||||||
|
.filter_map(|e| match e {
|
||||||
|
Extern::Func(f) => Some(f.clone()),
|
||||||
|
_ => None,
|
||||||
|
})
|
||||||
|
.collect::<Vec<_>>()
|
||||||
|
};
|
||||||
|
|
||||||
|
if funcs.is_empty() {
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
|
||||||
|
let nth = nth % funcs.len();
|
||||||
|
let f = funcs[nth].borrow();
|
||||||
|
let ty = f.r#type();
|
||||||
|
let params = match ty
|
||||||
|
.params()
|
||||||
|
.iter()
|
||||||
|
.map(|valty| dummy_value(valty))
|
||||||
|
.collect::<Result<Vec<_>, _>>()
|
||||||
|
{
|
||||||
|
Ok(p) => p,
|
||||||
|
Err(_) => continue,
|
||||||
|
};
|
||||||
|
let _ = f.call(¶ms);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|||||||
@@ -255,8 +255,8 @@ impl Drop for Mmap {
|
|||||||
use winapi::ctypes::c_void;
|
use winapi::ctypes::c_void;
|
||||||
use winapi::um::memoryapi::VirtualFree;
|
use winapi::um::memoryapi::VirtualFree;
|
||||||
use winapi::um::winnt::MEM_RELEASE;
|
use winapi::um::winnt::MEM_RELEASE;
|
||||||
let r = unsafe { VirtualFree(self.ptr as *mut c_void, self.len, MEM_RELEASE) };
|
let r = unsafe { VirtualFree(self.ptr as *mut c_void, 0, MEM_RELEASE) };
|
||||||
assert_eq!(r, 0);
|
assert_ne!(r, 0);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -100,11 +100,27 @@ pub fn instantiate(data: &[u8], bin_name: &str, workspace: Option<&Path>) -> any
|
|||||||
}
|
}
|
||||||
})
|
})
|
||||||
.collect::<Result<Vec<_>, _>>()?;
|
.collect::<Result<Vec<_>, _>>()?;
|
||||||
let _ = HostRef::new(Instance::new(&store, &module, &imports).context(format!(
|
|
||||||
|
let instance = HostRef::new(Instance::new(&store, &module, &imports).context(format!(
|
||||||
"error while instantiating Wasm module '{}'",
|
"error while instantiating Wasm module '{}'",
|
||||||
bin_name,
|
bin_name,
|
||||||
))?);
|
))?);
|
||||||
|
|
||||||
|
let export = instance
|
||||||
|
.borrow()
|
||||||
|
.find_export_by_name("_start")
|
||||||
|
.context("expected a _start export")?
|
||||||
|
.clone();
|
||||||
|
|
||||||
|
if let Err(trap) = export
|
||||||
|
.func()
|
||||||
|
.context("expected export to be a func")?
|
||||||
|
.borrow()
|
||||||
|
.call(&[])
|
||||||
|
{
|
||||||
|
bail!("trapped: {:?}", trap.borrow());
|
||||||
|
}
|
||||||
|
|
||||||
Ok(())
|
Ok(())
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -149,6 +149,12 @@ impl From<str::Utf8Error> for Error {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
impl From<ffi::NulError> for Error {
|
||||||
|
fn from(_: ffi::NulError) -> Self {
|
||||||
|
Self::Wasi(WasiError::EILSEQ)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
impl From<&ffi::NulError> for Error {
|
impl From<&ffi::NulError> for Error {
|
||||||
fn from(_: &ffi::NulError) -> Self {
|
fn from(_: &ffi::NulError) -> Self {
|
||||||
Self::Wasi(WasiError::EILSEQ)
|
Self::Wasi(WasiError::EILSEQ)
|
||||||
|
|||||||
@@ -149,6 +149,12 @@ impl From<str::Utf8Error> for Error {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
impl From<ffi::NulError> for Error {
|
||||||
|
fn from(_: ffi::NulError) -> Self {
|
||||||
|
Self::Wasi(WasiError::EILSEQ)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
impl From<&ffi::NulError> for Error {
|
impl From<&ffi::NulError> for Error {
|
||||||
fn from(_: &ffi::NulError) -> Self {
|
fn from(_: &ffi::NulError) -> Self {
|
||||||
Self::Wasi(WasiError::EILSEQ)
|
Self::Wasi(WasiError::EILSEQ)
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
//! This internal module consists of helper types and functions for dealing
|
//! This internal module consists of helper types and functions for dealing
|
||||||
//! with setting the file times specific to BSD-style *nixes.
|
//! with setting the file times specific to BSD-style *nixes.
|
||||||
use super::super::filetime::FileTime;
|
use crate::old::snapshot_0::{sys::unix::filetime::FileTime, Result};
|
||||||
use cfg_if::cfg_if;
|
use cfg_if::cfg_if;
|
||||||
use std::ffi::CStr;
|
use std::ffi::CStr;
|
||||||
use std::fs::File;
|
use std::fs::File;
|
||||||
@@ -41,8 +41,8 @@ pub(crate) fn utimensat(
|
|||||||
atime: FileTime,
|
atime: FileTime,
|
||||||
mtime: FileTime,
|
mtime: FileTime,
|
||||||
symlink_nofollow: bool,
|
symlink_nofollow: bool,
|
||||||
) -> io::Result<()> {
|
) -> Result<()> {
|
||||||
use super::super::filetime::{to_timespec, utimesat};
|
use crate::old::snapshot_0::sys::unix::filetime::to_timespec;
|
||||||
use std::ffi::CString;
|
use std::ffi::CString;
|
||||||
use std::os::unix::prelude::*;
|
use std::os::unix::prelude::*;
|
||||||
|
|
||||||
@@ -56,16 +56,16 @@ pub(crate) fn utimensat(
|
|||||||
};
|
};
|
||||||
|
|
||||||
let p = CString::new(path.as_bytes())?;
|
let p = CString::new(path.as_bytes())?;
|
||||||
let times = [to_timespec(&atime), to_timespec(&mtime)];
|
let times = [to_timespec(&atime)?, to_timespec(&mtime)?];
|
||||||
let rc = unsafe { func(dirfd.as_raw_fd(), p.as_ptr(), times.as_ptr(), flags) };
|
let rc = unsafe { func(dirfd.as_raw_fd(), p.as_ptr(), times.as_ptr(), flags) };
|
||||||
if rc == 0 {
|
if rc == 0 {
|
||||||
return Ok(());
|
return Ok(());
|
||||||
} else {
|
} else {
|
||||||
return Err(io::Error::last_os_error());
|
return Err(io::Error::last_os_error().into());
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
utimesat(dirfd, path, atime, mtime, symlink_nofollow)
|
super::utimesat::utimesat(dirfd, path, atime, mtime, symlink_nofollow)
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Wraps `fetch` specifically targetting `utimensat` symbol. If the symbol exists
|
/// Wraps `fetch` specifically targetting `utimensat` symbol. If the symbol exists
|
||||||
|
|||||||
@@ -0,0 +1,16 @@
|
|||||||
|
use crate::old::snapshot_0::{wasi, Result};
|
||||||
|
use std::convert::TryFrom;
|
||||||
|
|
||||||
|
pub(crate) const O_RSYNC: yanix::file::OFlag = yanix::file::OFlag::SYNC;
|
||||||
|
|
||||||
|
pub(crate) fn stdev_from_nix(dev: libc::dev_t) -> Result<wasi::__wasi_device_t> {
|
||||||
|
wasi::__wasi_device_t::try_from(dev).map_err(Into::into)
|
||||||
|
}
|
||||||
|
|
||||||
|
pub(crate) fn stino_from_nix(ino: libc::ino_t) -> Result<wasi::__wasi_inode_t> {
|
||||||
|
wasi::__wasi_device_t::try_from(ino).map_err(Into::into)
|
||||||
|
}
|
||||||
|
|
||||||
|
pub(crate) fn stnlink_from_nix(nlink: libc::nlink_t) -> Result<wasi::__wasi_linkcount_t> {
|
||||||
|
Ok(nlink.into())
|
||||||
|
}
|
||||||
@@ -1,18 +1,6 @@
|
|||||||
pub(crate) mod filetime;
|
pub(crate) mod filetime;
|
||||||
|
pub(crate) mod host_impl;
|
||||||
pub(crate) mod hostcalls_impl;
|
pub(crate) mod hostcalls_impl;
|
||||||
pub(crate) mod oshandle;
|
pub(crate) mod oshandle;
|
||||||
|
#[path = "../linux/utimesat.rs"]
|
||||||
pub(crate) mod host_impl {
|
pub(crate) mod utimesat;
|
||||||
use crate::old::snapshot_0::{wasi, Result};
|
|
||||||
use std::convert::TryFrom;
|
|
||||||
|
|
||||||
pub(crate) const O_RSYNC: yanix::file::OFlag = yanix::file::OFlag::SYNC;
|
|
||||||
|
|
||||||
pub(crate) fn stdev_from_nix(dev: libc::dev_t) -> Result<wasi::__wasi_device_t> {
|
|
||||||
wasi::__wasi_device_t::try_from(dev).map_err(Into::into)
|
|
||||||
}
|
|
||||||
|
|
||||||
pub(crate) fn stino_from_nix(ino: libc::ino_t) -> Result<wasi::__wasi_inode_t> {
|
|
||||||
wasi::__wasi_device_t::try_from(ino).map_err(Into::into)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|||||||
@@ -0,0 +1,36 @@
|
|||||||
|
//! This internal module consists of helper types and functions for dealing
|
||||||
|
//! with setting the file times specific to Emscripten.
|
||||||
|
use crate::old::snapshot_0::{sys::unix::filetime::FileTime, Result};
|
||||||
|
use std::fs::File;
|
||||||
|
use std::io;
|
||||||
|
|
||||||
|
pub(crate) const UTIME_NOW: i32 = 1_073_741_823;
|
||||||
|
pub(crate) const UTIME_OMIT: i32 = 1_073_741_822;
|
||||||
|
|
||||||
|
/// Wrapper for `utimensat` syscall. In Emscripten, there is no point in dynamically resolving
|
||||||
|
/// if `utimensat` is available as it always was and will be.
|
||||||
|
pub(crate) fn utimensat(
|
||||||
|
dirfd: &File,
|
||||||
|
path: &str,
|
||||||
|
atime: FileTime,
|
||||||
|
mtime: FileTime,
|
||||||
|
symlink_nofollow: bool,
|
||||||
|
) -> Result<()> {
|
||||||
|
use crate::old::snapshot_0::sys::unix::filetime::to_timespec;
|
||||||
|
use std::ffi::CString;
|
||||||
|
use std::os::unix::prelude::*;
|
||||||
|
|
||||||
|
let flags = if symlink_nofollow {
|
||||||
|
libc::AT_SYMLINK_NOFOLLOW
|
||||||
|
} else {
|
||||||
|
0
|
||||||
|
};
|
||||||
|
let p = CString::new(path.as_bytes())?;
|
||||||
|
let times = [to_timespec(&atime)?, to_timespec(&mtime)?];
|
||||||
|
let rc = unsafe { libc::utimensat(dirfd.as_raw_fd(), p.as_ptr(), times.as_ptr(), flags) };
|
||||||
|
if rc == 0 {
|
||||||
|
Ok(())
|
||||||
|
} else {
|
||||||
|
Err(io::Error::last_os_error().into())
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -0,0 +1,15 @@
|
|||||||
|
use crate::old::snapshot_0::{wasi, Result};
|
||||||
|
|
||||||
|
pub(crate) const O_RSYNC: yanix::file::OFlag = yanix::file::OFlag::RSYNC;
|
||||||
|
|
||||||
|
pub(crate) fn stdev_from_nix(dev: libc::dev_t) -> Result<wasi::__wasi_device_t> {
|
||||||
|
Ok(wasi::__wasi_device_t::from(dev))
|
||||||
|
}
|
||||||
|
|
||||||
|
pub(crate) fn stino_from_nix(ino: libc::ino_t) -> Result<wasi::__wasi_inode_t> {
|
||||||
|
Ok(wasi::__wasi_device_t::from(ino))
|
||||||
|
}
|
||||||
|
|
||||||
|
pub(crate) fn stnlink_from_nix(nlink: libc::nlink_t) -> Result<wasi::__wasi_linkcount_t> {
|
||||||
|
Ok(nlink)
|
||||||
|
}
|
||||||
@@ -0,0 +1,6 @@
|
|||||||
|
pub(crate) mod filetime;
|
||||||
|
pub(crate) mod host_impl;
|
||||||
|
#[path = "../linux/hostcalls_impl.rs"]
|
||||||
|
pub(crate) mod hostcalls_impl;
|
||||||
|
#[path = "../linux/oshandle.rs"]
|
||||||
|
pub(crate) mod oshandle;
|
||||||
@@ -1,24 +1,11 @@
|
|||||||
use crate::old::snapshot_0::fdentry::{Descriptor, OsHandleRef};
|
use crate::old::snapshot_0::fdentry::{Descriptor, OsHandleRef};
|
||||||
use crate::old::snapshot_0::{wasi, Error, Result};
|
use crate::old::snapshot_0::{sys::unix::sys_impl, wasi, Error, Result};
|
||||||
use std::fs::File;
|
use std::fs::File;
|
||||||
use std::io;
|
use std::io;
|
||||||
use std::mem::ManuallyDrop;
|
use std::mem::ManuallyDrop;
|
||||||
use std::os::unix::prelude::{AsRawFd, FileTypeExt, FromRawFd, RawFd};
|
use std::os::unix::prelude::{AsRawFd, FileTypeExt, FromRawFd, RawFd};
|
||||||
|
|
||||||
cfg_if::cfg_if! {
|
pub(crate) use sys_impl::oshandle::*;
|
||||||
if #[cfg(target_os = "linux")] {
|
|
||||||
pub(crate) use super::linux::oshandle::*;
|
|
||||||
} else if #[cfg(any(
|
|
||||||
target_os = "macos",
|
|
||||||
target_os = "netbsd",
|
|
||||||
target_os = "freebsd",
|
|
||||||
target_os = "openbsd",
|
|
||||||
target_os = "ios",
|
|
||||||
target_os = "dragonfly"
|
|
||||||
))] {
|
|
||||||
pub(crate) use super::bsd::oshandle::*;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
impl AsRawFd for Descriptor {
|
impl AsRawFd for Descriptor {
|
||||||
fn as_raw_fd(&self) -> RawFd {
|
fn as_raw_fd(&self) -> RawFd {
|
||||||
|
|||||||
@@ -6,21 +6,30 @@
|
|||||||
//! Kudos @alexcrichton!
|
//! Kudos @alexcrichton!
|
||||||
//!
|
//!
|
||||||
//! [filetime]: https://github.com/alexcrichton/filetime
|
//! [filetime]: https://github.com/alexcrichton/filetime
|
||||||
use std::fs::{self, File};
|
use crate::old::snapshot_0::Result;
|
||||||
use std::io;
|
use std::convert::TryInto;
|
||||||
|
|
||||||
|
pub(crate) use super::sys_impl::filetime::*;
|
||||||
|
|
||||||
cfg_if::cfg_if! {
|
cfg_if::cfg_if! {
|
||||||
if #[cfg(target_os = "linux")] {
|
if #[cfg(not(target_os = "emscripten"))] {
|
||||||
pub(crate) use super::linux::filetime::*;
|
fn filetime_to_timespec(ft: &filetime::FileTime) -> Result<libc::timespec> {
|
||||||
} else if #[cfg(any(
|
Ok(
|
||||||
target_os = "macos",
|
libc::timespec {
|
||||||
target_os = "netbsd",
|
tv_sec: ft.seconds(),
|
||||||
target_os = "freebsd",
|
tv_nsec: ft.nanoseconds().try_into()?,
|
||||||
target_os = "openbsd",
|
}
|
||||||
target_os = "ios",
|
)
|
||||||
target_os = "dragonfly"
|
}
|
||||||
))] {
|
} else {
|
||||||
pub(crate) use super::bsd::filetime::*;
|
fn filetime_to_timespec(ft: &filetime::FileTime) -> Result<libc::timespec> {
|
||||||
|
Ok(
|
||||||
|
libc::timespec {
|
||||||
|
tv_sec: ft.seconds().try_into()?,
|
||||||
|
tv_nsec: ft.nanoseconds().try_into()?,
|
||||||
|
}
|
||||||
|
)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -35,91 +44,6 @@ pub(crate) enum FileTime {
|
|||||||
FileTime(filetime::FileTime),
|
FileTime(filetime::FileTime),
|
||||||
}
|
}
|
||||||
|
|
||||||
/// For a provided pair of access and modified `FileTime`s, converts the input to
|
|
||||||
/// `filetime::FileTime` used later in `utimensat` function. For variants `FileTime::Now`
|
|
||||||
/// and `FileTime::Omit`, this function will make two syscalls: either accessing current
|
|
||||||
/// system time, or accessing the file's metadata.
|
|
||||||
///
|
|
||||||
/// The original implementation can be found here: [filetime::unix::get_times].
|
|
||||||
///
|
|
||||||
/// [filetime::unix::get_times]: https://github.com/alexcrichton/filetime/blob/master/src/unix/utimes.rs#L42
|
|
||||||
fn get_times(
|
|
||||||
atime: FileTime,
|
|
||||||
mtime: FileTime,
|
|
||||||
current: impl Fn() -> io::Result<fs::Metadata>,
|
|
||||||
) -> io::Result<(filetime::FileTime, filetime::FileTime)> {
|
|
||||||
use std::time::SystemTime;
|
|
||||||
|
|
||||||
let atime = match atime {
|
|
||||||
FileTime::Now => {
|
|
||||||
let time = SystemTime::now();
|
|
||||||
filetime::FileTime::from_system_time(time)
|
|
||||||
}
|
|
||||||
FileTime::Omit => {
|
|
||||||
let meta = current()?;
|
|
||||||
filetime::FileTime::from_last_access_time(&meta)
|
|
||||||
}
|
|
||||||
FileTime::FileTime(ft) => ft,
|
|
||||||
};
|
|
||||||
|
|
||||||
let mtime = match mtime {
|
|
||||||
FileTime::Now => {
|
|
||||||
let time = SystemTime::now();
|
|
||||||
filetime::FileTime::from_system_time(time)
|
|
||||||
}
|
|
||||||
FileTime::Omit => {
|
|
||||||
let meta = current()?;
|
|
||||||
filetime::FileTime::from_last_modification_time(&meta)
|
|
||||||
}
|
|
||||||
FileTime::FileTime(ft) => ft,
|
|
||||||
};
|
|
||||||
|
|
||||||
Ok((atime, mtime))
|
|
||||||
}
|
|
||||||
|
|
||||||
/// Combines `openat` with `utimes` to emulate `utimensat` on platforms where it is
|
|
||||||
/// not available. The logic for setting file times is based on [filetime::unix::set_file_handles_times].
|
|
||||||
///
|
|
||||||
/// [filetime::unix::set_file_handles_times]: https://github.com/alexcrichton/filetime/blob/master/src/unix/utimes.rs#L24
|
|
||||||
pub(crate) fn utimesat(
|
|
||||||
dirfd: &File,
|
|
||||||
path: &str,
|
|
||||||
atime: FileTime,
|
|
||||||
mtime: FileTime,
|
|
||||||
symlink_nofollow: bool,
|
|
||||||
) -> io::Result<()> {
|
|
||||||
use std::ffi::CString;
|
|
||||||
use std::os::unix::prelude::*;
|
|
||||||
// emulate *at syscall by reading the path from a combination of
|
|
||||||
// (fd, path)
|
|
||||||
let p = CString::new(path.as_bytes())?;
|
|
||||||
let mut flags = libc::O_RDWR;
|
|
||||||
if symlink_nofollow {
|
|
||||||
flags |= libc::O_NOFOLLOW;
|
|
||||||
}
|
|
||||||
let fd = unsafe { libc::openat(dirfd.as_raw_fd(), p.as_ptr(), flags) };
|
|
||||||
let f = unsafe { File::from_raw_fd(fd) };
|
|
||||||
let (atime, mtime) = get_times(atime, mtime, || f.metadata())?;
|
|
||||||
let times = [to_timeval(atime), to_timeval(mtime)];
|
|
||||||
let rc = unsafe { libc::futimes(f.as_raw_fd(), times.as_ptr()) };
|
|
||||||
return if rc == 0 {
|
|
||||||
Ok(())
|
|
||||||
} else {
|
|
||||||
Err(io::Error::last_os_error())
|
|
||||||
};
|
|
||||||
}
|
|
||||||
|
|
||||||
/// Converts `filetime::FileTime` to `libc::timeval`. This function was taken directly from
|
|
||||||
/// [filetime] crate.
|
|
||||||
///
|
|
||||||
/// [filetime]: https://github.com/alexcrichton/filetime/blob/master/src/unix/utimes.rs#L93
|
|
||||||
fn to_timeval(ft: filetime::FileTime) -> libc::timeval {
|
|
||||||
libc::timeval {
|
|
||||||
tv_sec: ft.seconds(),
|
|
||||||
tv_usec: (ft.nanoseconds() / 1000) as libc::suseconds_t,
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/// Converts `FileTime` to `libc::timespec`. If `FileTime::Now` variant is specified, this
|
/// Converts `FileTime` to `libc::timespec`. If `FileTime::Now` variant is specified, this
|
||||||
/// resolves to `UTIME_NOW` special const, `FileTime::Omit` variant resolves to `UTIME_OMIT`, and
|
/// resolves to `UTIME_NOW` special const, `FileTime::Omit` variant resolves to `UTIME_OMIT`, and
|
||||||
/// `FileTime::FileTime(ft)` where `ft := filetime::FileTime` uses [filetime] crate's original
|
/// `FileTime::FileTime(ft)` where `ft := filetime::FileTime` uses [filetime] crate's original
|
||||||
@@ -127,8 +51,8 @@ fn to_timeval(ft: filetime::FileTime) -> libc::timeval {
|
|||||||
///
|
///
|
||||||
/// [filetime]: https://github.com/alexcrichton/filetime
|
/// [filetime]: https://github.com/alexcrichton/filetime
|
||||||
/// [filetime::unix::to_timespec]: https://github.com/alexcrichton/filetime/blob/master/src/unix/mod.rs#L30
|
/// [filetime::unix::to_timespec]: https://github.com/alexcrichton/filetime/blob/master/src/unix/mod.rs#L30
|
||||||
pub(crate) fn to_timespec(ft: &FileTime) -> libc::timespec {
|
pub(crate) fn to_timespec(ft: &FileTime) -> Result<libc::timespec> {
|
||||||
match ft {
|
let ts = match ft {
|
||||||
FileTime::Now => libc::timespec {
|
FileTime::Now => libc::timespec {
|
||||||
tv_sec: 0,
|
tv_sec: 0,
|
||||||
tv_nsec: UTIME_NOW,
|
tv_nsec: UTIME_NOW,
|
||||||
@@ -137,13 +61,7 @@ pub(crate) fn to_timespec(ft: &FileTime) -> libc::timespec {
|
|||||||
tv_sec: 0,
|
tv_sec: 0,
|
||||||
tv_nsec: UTIME_OMIT,
|
tv_nsec: UTIME_OMIT,
|
||||||
},
|
},
|
||||||
// `filetime::FileTime`'s fields are normalised by definition. `ft.seconds()` return the number
|
FileTime::FileTime(ft) => filetime_to_timespec(ft)?,
|
||||||
// of whole seconds, while `ft.nanoseconds()` returns only fractional part expressed in
|
};
|
||||||
// nanoseconds, as underneath it uses `std::time::Duration::subsec_nanos` to populate the
|
Ok(ts)
|
||||||
// `filetime::FileTime::nanoseconds` field. It is, therefore, OK to do an `as` cast here.
|
|
||||||
FileTime::FileTime(ft) => libc::timespec {
|
|
||||||
tv_sec: ft.seconds(),
|
|
||||||
tv_nsec: ft.nanoseconds() as _,
|
|
||||||
},
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -3,7 +3,7 @@
|
|||||||
#![allow(non_snake_case)]
|
#![allow(non_snake_case)]
|
||||||
#![allow(dead_code)]
|
#![allow(dead_code)]
|
||||||
use crate::old::snapshot_0::host::FileType;
|
use crate::old::snapshot_0::host::FileType;
|
||||||
use crate::old::snapshot_0::{helpers, wasi, Error, Result};
|
use crate::old::snapshot_0::{helpers, sys::unix::sys_impl, wasi, Error, Result};
|
||||||
use std::ffi::OsStr;
|
use std::ffi::OsStr;
|
||||||
use std::os::unix::prelude::OsStrExt;
|
use std::os::unix::prelude::OsStrExt;
|
||||||
use yanix::{
|
use yanix::{
|
||||||
@@ -11,20 +11,7 @@ use yanix::{
|
|||||||
Errno,
|
Errno,
|
||||||
};
|
};
|
||||||
|
|
||||||
cfg_if::cfg_if! {
|
pub(crate) use sys_impl::host_impl::*;
|
||||||
if #[cfg(target_os = "linux")] {
|
|
||||||
pub(crate) use super::linux::host_impl::*;
|
|
||||||
} else if #[cfg(any(
|
|
||||||
target_os = "macos",
|
|
||||||
target_os = "netbsd",
|
|
||||||
target_os = "freebsd",
|
|
||||||
target_os = "openbsd",
|
|
||||||
target_os = "ios",
|
|
||||||
target_os = "dragonfly"
|
|
||||||
))] {
|
|
||||||
pub(crate) use super::bsd::host_impl::*;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
pub(crate) fn errno_from_nix(errno: Errno) -> Error {
|
pub(crate) fn errno_from_nix(errno: Errno) -> Error {
|
||||||
match errno {
|
match errno {
|
||||||
@@ -197,7 +184,7 @@ pub(crate) fn filestat_from_nix(filestat: libc::stat) -> Result<wasi::__wasi_fil
|
|||||||
Ok(wasi::__wasi_filestat_t {
|
Ok(wasi::__wasi_filestat_t {
|
||||||
dev,
|
dev,
|
||||||
ino,
|
ino,
|
||||||
nlink: filestat.st_nlink as wasi::__wasi_linkcount_t,
|
nlink: stnlink_from_nix(filestat.st_nlink)?,
|
||||||
size: filestat.st_size as wasi::__wasi_filesize_t,
|
size: filestat.st_size as wasi::__wasi_filesize_t,
|
||||||
atim,
|
atim,
|
||||||
ctim,
|
ctim,
|
||||||
|
|||||||
@@ -3,27 +3,14 @@
|
|||||||
use crate::old::snapshot_0::helpers::systemtime_to_timestamp;
|
use crate::old::snapshot_0::helpers::systemtime_to_timestamp;
|
||||||
use crate::old::snapshot_0::host::{Dirent, FileType};
|
use crate::old::snapshot_0::host::{Dirent, FileType};
|
||||||
use crate::old::snapshot_0::hostcalls_impl::PathGet;
|
use crate::old::snapshot_0::hostcalls_impl::PathGet;
|
||||||
use crate::old::snapshot_0::sys::{fdentry_impl::OsHandle, host_impl};
|
use crate::old::snapshot_0::sys::{fdentry_impl::OsHandle, host_impl, unix::sys_impl};
|
||||||
use crate::old::snapshot_0::{wasi, Error, Result};
|
use crate::old::snapshot_0::{wasi, Error, Result};
|
||||||
use std::convert::TryInto;
|
use std::convert::TryInto;
|
||||||
use std::fs::{File, Metadata};
|
use std::fs::{File, Metadata};
|
||||||
use std::os::unix::fs::FileExt;
|
use std::os::unix::fs::FileExt;
|
||||||
use std::os::unix::prelude::{AsRawFd, FromRawFd};
|
use std::os::unix::prelude::{AsRawFd, FromRawFd};
|
||||||
|
|
||||||
cfg_if::cfg_if! {
|
pub(crate) use sys_impl::hostcalls_impl::*;
|
||||||
if #[cfg(target_os = "linux")] {
|
|
||||||
pub(crate) use super::super::linux::hostcalls_impl::*;
|
|
||||||
} else if #[cfg(any(
|
|
||||||
target_os = "macos",
|
|
||||||
target_os = "netbsd",
|
|
||||||
target_os = "freebsd",
|
|
||||||
target_os = "openbsd",
|
|
||||||
target_os = "ios",
|
|
||||||
target_os = "dragonfly"
|
|
||||||
))] {
|
|
||||||
pub(crate) use super::super::bsd::hostcalls_impl::*;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
pub(crate) fn fd_pread(
|
pub(crate) fn fd_pread(
|
||||||
file: &File,
|
file: &File,
|
||||||
@@ -342,7 +329,7 @@ pub(crate) fn fd_readdir<'a>(
|
|||||||
dir.rewind();
|
dir.rewind();
|
||||||
} else {
|
} else {
|
||||||
log::trace!(" | fd_readdir: doing seekdir to {}", cookie);
|
log::trace!(" | fd_readdir: doing seekdir to {}", cookie);
|
||||||
let loc = unsafe { SeekLoc::from_raw(cookie as i64) };
|
let loc = unsafe { SeekLoc::from_raw(cookie as i64)? };
|
||||||
dir.seek(loc);
|
dir.seek(loc);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -356,7 +343,7 @@ pub(crate) fn fd_readdir<'a>(
|
|||||||
.to_owned(),
|
.to_owned(),
|
||||||
ino: entry.ino(),
|
ino: entry.ino(),
|
||||||
ftype: entry.file_type().into(),
|
ftype: entry.file_type().into(),
|
||||||
cookie: entry.seek_loc().to_raw().try_into()?,
|
cookie: entry.seek_loc()?.to_raw().try_into()?,
|
||||||
})
|
})
|
||||||
}))
|
}))
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
//! This internal module consists of helper types and functions for dealing
|
//! This internal module consists of helper types and functions for dealing
|
||||||
//! with setting the file times specific to Linux.
|
//! with setting the file times specific to Linux.
|
||||||
use super::super::filetime::FileTime;
|
use crate::old::snapshot_0::{sys::unix::filetime::FileTime, Result};
|
||||||
use std::fs::File;
|
use std::fs::File;
|
||||||
use std::io;
|
use std::io;
|
||||||
use std::sync::atomic::{AtomicBool, Ordering::Relaxed};
|
use std::sync::atomic::{AtomicBool, Ordering::Relaxed};
|
||||||
@@ -20,8 +20,8 @@ pub(crate) fn utimensat(
|
|||||||
atime: FileTime,
|
atime: FileTime,
|
||||||
mtime: FileTime,
|
mtime: FileTime,
|
||||||
symlink_nofollow: bool,
|
symlink_nofollow: bool,
|
||||||
) -> io::Result<()> {
|
) -> Result<()> {
|
||||||
use super::super::filetime::{to_timespec, utimesat};
|
use crate::old::snapshot_0::sys::unix::filetime::to_timespec;
|
||||||
use std::ffi::CString;
|
use std::ffi::CString;
|
||||||
use std::os::unix::prelude::*;
|
use std::os::unix::prelude::*;
|
||||||
|
|
||||||
@@ -36,7 +36,7 @@ pub(crate) fn utimensat(
|
|||||||
static INVALID: AtomicBool = AtomicBool::new(false);
|
static INVALID: AtomicBool = AtomicBool::new(false);
|
||||||
if !INVALID.load(Relaxed) {
|
if !INVALID.load(Relaxed) {
|
||||||
let p = CString::new(path.as_bytes())?;
|
let p = CString::new(path.as_bytes())?;
|
||||||
let times = [to_timespec(&atime), to_timespec(&mtime)];
|
let times = [to_timespec(&atime)?, to_timespec(&mtime)?];
|
||||||
let rc = unsafe {
|
let rc = unsafe {
|
||||||
libc::syscall(
|
libc::syscall(
|
||||||
libc::SYS_utimensat,
|
libc::SYS_utimensat,
|
||||||
@@ -53,9 +53,9 @@ pub(crate) fn utimensat(
|
|||||||
if err.raw_os_error() == Some(libc::ENOSYS) {
|
if err.raw_os_error() == Some(libc::ENOSYS) {
|
||||||
INVALID.store(true, Relaxed);
|
INVALID.store(true, Relaxed);
|
||||||
} else {
|
} else {
|
||||||
return Err(err);
|
return Err(err.into());
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
utimesat(dirfd, path, atime, mtime, symlink_nofollow)
|
super::utimesat::utimesat(dirfd, path, atime, mtime, symlink_nofollow)
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -0,0 +1,16 @@
|
|||||||
|
use crate::old::snapshot_0::{wasi, Result};
|
||||||
|
use std::convert::TryInto;
|
||||||
|
|
||||||
|
pub(crate) const O_RSYNC: yanix::file::OFlag = yanix::file::OFlag::RSYNC;
|
||||||
|
|
||||||
|
pub(crate) fn stdev_from_nix(dev: libc::dev_t) -> Result<wasi::__wasi_device_t> {
|
||||||
|
Ok(wasi::__wasi_device_t::from(dev))
|
||||||
|
}
|
||||||
|
|
||||||
|
pub(crate) fn stino_from_nix(ino: libc::ino_t) -> Result<wasi::__wasi_inode_t> {
|
||||||
|
Ok(wasi::__wasi_device_t::from(ino))
|
||||||
|
}
|
||||||
|
|
||||||
|
pub(crate) fn stnlink_from_nix(nlink: libc::nlink_t) -> Result<wasi::__wasi_linkcount_t> {
|
||||||
|
nlink.try_into().map_err(Into::into)
|
||||||
|
}
|
||||||
@@ -1,17 +1,5 @@
|
|||||||
pub(crate) mod filetime;
|
pub(crate) mod filetime;
|
||||||
|
pub(crate) mod host_impl;
|
||||||
pub(crate) mod hostcalls_impl;
|
pub(crate) mod hostcalls_impl;
|
||||||
pub(crate) mod oshandle;
|
pub(crate) mod oshandle;
|
||||||
|
pub(crate) mod utimesat;
|
||||||
pub(crate) mod host_impl {
|
|
||||||
use crate::old::snapshot_0::{wasi, Result};
|
|
||||||
|
|
||||||
pub(crate) const O_RSYNC: yanix::file::OFlag = yanix::file::OFlag::RSYNC;
|
|
||||||
|
|
||||||
pub(crate) fn stdev_from_nix(dev: libc::dev_t) -> Result<wasi::__wasi_device_t> {
|
|
||||||
Ok(wasi::__wasi_device_t::from(dev))
|
|
||||||
}
|
|
||||||
|
|
||||||
pub(crate) fn stino_from_nix(ino: libc::ino_t) -> Result<wasi::__wasi_inode_t> {
|
|
||||||
Ok(wasi::__wasi_device_t::from(ino))
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|||||||
@@ -0,0 +1,88 @@
|
|||||||
|
use crate::old::snapshot_0::sys::unix::filetime::FileTime;
|
||||||
|
use crate::old::snapshot_0::Result;
|
||||||
|
use std::{fs, io};
|
||||||
|
|
||||||
|
/// Combines `openat` with `utimes` to emulate `utimensat` on platforms where it is
|
||||||
|
/// not available. The logic for setting file times is based on [filetime::unix::set_file_handles_times].
|
||||||
|
///
|
||||||
|
/// [filetime::unix::set_file_handles_times]: https://github.com/alexcrichton/filetime/blob/master/src/unix/utimes.rs#L24
|
||||||
|
pub(crate) fn utimesat(
|
||||||
|
dirfd: &fs::File,
|
||||||
|
path: &str,
|
||||||
|
atime: FileTime,
|
||||||
|
mtime: FileTime,
|
||||||
|
symlink_nofollow: bool,
|
||||||
|
) -> Result<()> {
|
||||||
|
use std::ffi::CString;
|
||||||
|
use std::os::unix::prelude::*;
|
||||||
|
// emulate *at syscall by reading the path from a combination of
|
||||||
|
// (fd, path)
|
||||||
|
let p = CString::new(path.as_bytes())?;
|
||||||
|
let mut flags = libc::O_RDWR;
|
||||||
|
if symlink_nofollow {
|
||||||
|
flags |= libc::O_NOFOLLOW;
|
||||||
|
}
|
||||||
|
let fd = unsafe { libc::openat(dirfd.as_raw_fd(), p.as_ptr(), flags) };
|
||||||
|
let f = unsafe { fs::File::from_raw_fd(fd) };
|
||||||
|
let (atime, mtime) = get_times(atime, mtime, || f.metadata().map_err(Into::into))?;
|
||||||
|
let times = [to_timeval(atime), to_timeval(mtime)];
|
||||||
|
let rc = unsafe { libc::futimes(f.as_raw_fd(), times.as_ptr()) };
|
||||||
|
if rc == 0 {
|
||||||
|
Ok(())
|
||||||
|
} else {
|
||||||
|
Err(io::Error::last_os_error().into())
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// Converts `filetime::FileTime` to `libc::timeval`. This function was taken directly from
|
||||||
|
/// [filetime] crate.
|
||||||
|
///
|
||||||
|
/// [filetime]: https://github.com/alexcrichton/filetime/blob/master/src/unix/utimes.rs#L93
|
||||||
|
fn to_timeval(ft: filetime::FileTime) -> libc::timeval {
|
||||||
|
libc::timeval {
|
||||||
|
tv_sec: ft.seconds(),
|
||||||
|
tv_usec: (ft.nanoseconds() / 1000) as libc::suseconds_t,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// For a provided pair of access and modified `FileTime`s, converts the input to
|
||||||
|
/// `filetime::FileTime` used later in `utimensat` function. For variants `FileTime::Now`
|
||||||
|
/// and `FileTime::Omit`, this function will make two syscalls: either accessing current
|
||||||
|
/// system time, or accessing the file's metadata.
|
||||||
|
///
|
||||||
|
/// The original implementation can be found here: [filetime::unix::get_times].
|
||||||
|
///
|
||||||
|
/// [filetime::unix::get_times]: https://github.com/alexcrichton/filetime/blob/master/src/unix/utimes.rs#L42
|
||||||
|
fn get_times(
|
||||||
|
atime: FileTime,
|
||||||
|
mtime: FileTime,
|
||||||
|
current: impl Fn() -> Result<fs::Metadata>,
|
||||||
|
) -> Result<(filetime::FileTime, filetime::FileTime)> {
|
||||||
|
use std::time::SystemTime;
|
||||||
|
|
||||||
|
let atime = match atime {
|
||||||
|
FileTime::Now => {
|
||||||
|
let time = SystemTime::now();
|
||||||
|
filetime::FileTime::from_system_time(time)
|
||||||
|
}
|
||||||
|
FileTime::Omit => {
|
||||||
|
let meta = current()?;
|
||||||
|
filetime::FileTime::from_last_access_time(&meta)
|
||||||
|
}
|
||||||
|
FileTime::FileTime(ft) => ft,
|
||||||
|
};
|
||||||
|
|
||||||
|
let mtime = match mtime {
|
||||||
|
FileTime::Now => {
|
||||||
|
let time = SystemTime::now();
|
||||||
|
filetime::FileTime::from_system_time(time)
|
||||||
|
}
|
||||||
|
FileTime::Omit => {
|
||||||
|
let meta = current()?;
|
||||||
|
filetime::FileTime::from_last_modification_time(&meta)
|
||||||
|
}
|
||||||
|
FileTime::FileTime(ft) => ft,
|
||||||
|
};
|
||||||
|
|
||||||
|
Ok((atime, mtime))
|
||||||
|
}
|
||||||
@@ -4,17 +4,23 @@ pub(crate) mod hostcalls_impl;
|
|||||||
|
|
||||||
mod filetime;
|
mod filetime;
|
||||||
|
|
||||||
#[cfg(any(
|
cfg_if::cfg_if! {
|
||||||
target_os = "macos",
|
if #[cfg(target_os = "linux")] {
|
||||||
target_os = "netbsd",
|
mod linux;
|
||||||
target_os = "freebsd",
|
use self::linux as sys_impl;
|
||||||
target_os = "openbsd",
|
} else if #[cfg(target_os = "emscripten")] {
|
||||||
target_os = "ios",
|
mod emscripten;
|
||||||
target_os = "dragonfly"
|
use self::emscripten as sys_impl;
|
||||||
))]
|
} else if #[cfg(any(target_os = "macos",
|
||||||
mod bsd;
|
target_os = "netbsd",
|
||||||
#[cfg(target_os = "linux")]
|
target_os = "freebsd",
|
||||||
mod linux;
|
target_os = "openbsd",
|
||||||
|
target_os = "ios",
|
||||||
|
target_os = "dragonfly"))] {
|
||||||
|
mod bsd;
|
||||||
|
use self::bsd as sys_impl;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
use crate::old::snapshot_0::Result;
|
use crate::old::snapshot_0::Result;
|
||||||
use std::fs::{File, OpenOptions};
|
use std::fs::{File, OpenOptions};
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
//! This internal module consists of helper types and functions for dealing
|
//! This internal module consists of helper types and functions for dealing
|
||||||
//! with setting the file times specific to BSD-style *nixes.
|
//! with setting the file times specific to BSD-style *nixes.
|
||||||
use super::super::filetime::FileTime;
|
use crate::{sys::unix::filetime::FileTime, Result};
|
||||||
use cfg_if::cfg_if;
|
use cfg_if::cfg_if;
|
||||||
use std::ffi::CStr;
|
use std::ffi::CStr;
|
||||||
use std::fs::File;
|
use std::fs::File;
|
||||||
@@ -41,8 +41,8 @@ pub(crate) fn utimensat(
|
|||||||
atime: FileTime,
|
atime: FileTime,
|
||||||
mtime: FileTime,
|
mtime: FileTime,
|
||||||
symlink_nofollow: bool,
|
symlink_nofollow: bool,
|
||||||
) -> io::Result<()> {
|
) -> Result<()> {
|
||||||
use super::super::filetime::{to_timespec, utimesat};
|
use crate::sys::unix::filetime::to_timespec;
|
||||||
use std::ffi::CString;
|
use std::ffi::CString;
|
||||||
use std::os::unix::prelude::*;
|
use std::os::unix::prelude::*;
|
||||||
|
|
||||||
@@ -56,16 +56,16 @@ pub(crate) fn utimensat(
|
|||||||
};
|
};
|
||||||
|
|
||||||
let p = CString::new(path.as_bytes())?;
|
let p = CString::new(path.as_bytes())?;
|
||||||
let times = [to_timespec(&atime), to_timespec(&mtime)];
|
let times = [to_timespec(&atime)?, to_timespec(&mtime)?];
|
||||||
let rc = unsafe { func(dirfd.as_raw_fd(), p.as_ptr(), times.as_ptr(), flags) };
|
let rc = unsafe { func(dirfd.as_raw_fd(), p.as_ptr(), times.as_ptr(), flags) };
|
||||||
if rc == 0 {
|
if rc == 0 {
|
||||||
return Ok(());
|
return Ok(());
|
||||||
} else {
|
} else {
|
||||||
return Err(io::Error::last_os_error());
|
return Err(io::Error::last_os_error().into());
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
utimesat(dirfd, path, atime, mtime, symlink_nofollow)
|
super::utimesat::utimesat(dirfd, path, atime, mtime, symlink_nofollow)
|
||||||
}
|
}
|
||||||
|
|
||||||
/// Wraps `fetch` specifically targetting `utimensat` symbol. If the symbol exists
|
/// Wraps `fetch` specifically targetting `utimensat` symbol. If the symbol exists
|
||||||
|
|||||||
12
crates/wasi-common/src/sys/unix/bsd/host_impl.rs
Normal file
12
crates/wasi-common/src/sys/unix/bsd/host_impl.rs
Normal file
@@ -0,0 +1,12 @@
|
|||||||
|
use crate::{wasi, Result};
|
||||||
|
use std::convert::TryFrom;
|
||||||
|
|
||||||
|
pub(crate) const O_RSYNC: yanix::file::OFlag = yanix::file::OFlag::SYNC;
|
||||||
|
|
||||||
|
pub(crate) fn stdev_from_nix(dev: libc::dev_t) -> Result<wasi::__wasi_device_t> {
|
||||||
|
wasi::__wasi_device_t::try_from(dev).map_err(Into::into)
|
||||||
|
}
|
||||||
|
|
||||||
|
pub(crate) fn stino_from_nix(ino: libc::ino_t) -> Result<wasi::__wasi_inode_t> {
|
||||||
|
wasi::__wasi_device_t::try_from(ino).map_err(Into::into)
|
||||||
|
}
|
||||||
@@ -1,18 +1,6 @@
|
|||||||
pub(crate) mod filetime;
|
pub(crate) mod filetime;
|
||||||
|
pub(crate) mod host_impl;
|
||||||
pub(crate) mod hostcalls_impl;
|
pub(crate) mod hostcalls_impl;
|
||||||
pub(crate) mod oshandle;
|
pub(crate) mod oshandle;
|
||||||
|
#[path = "../linux/utimesat.rs"]
|
||||||
pub(crate) mod host_impl {
|
pub(crate) mod utimesat;
|
||||||
use crate::{wasi, Result};
|
|
||||||
use std::convert::TryFrom;
|
|
||||||
|
|
||||||
pub(crate) const O_RSYNC: yanix::file::OFlag = yanix::file::OFlag::SYNC;
|
|
||||||
|
|
||||||
pub(crate) fn stdev_from_nix(dev: libc::dev_t) -> Result<wasi::__wasi_device_t> {
|
|
||||||
wasi::__wasi_device_t::try_from(dev).map_err(Into::into)
|
|
||||||
}
|
|
||||||
|
|
||||||
pub(crate) fn stino_from_nix(ino: libc::ino_t) -> Result<wasi::__wasi_inode_t> {
|
|
||||||
wasi::__wasi_device_t::try_from(ino).map_err(Into::into)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|||||||
36
crates/wasi-common/src/sys/unix/emscripten/filetime.rs
Normal file
36
crates/wasi-common/src/sys/unix/emscripten/filetime.rs
Normal file
@@ -0,0 +1,36 @@
|
|||||||
|
//! This internal module consists of helper types and functions for dealing
|
||||||
|
//! with setting the file times specific to Emscripten.
|
||||||
|
use crate::{sys::unix::filetime::FileTime, Result};
|
||||||
|
use std::fs::File;
|
||||||
|
use std::io;
|
||||||
|
|
||||||
|
pub(crate) const UTIME_NOW: i32 = 1_073_741_823;
|
||||||
|
pub(crate) const UTIME_OMIT: i32 = 1_073_741_822;
|
||||||
|
|
||||||
|
/// Wrapper for `utimensat` syscall. In Emscripten, there is no point in dynamically resolving
|
||||||
|
/// if `utimensat` is available as it always was and will be.
|
||||||
|
pub(crate) fn utimensat(
|
||||||
|
dirfd: &File,
|
||||||
|
path: &str,
|
||||||
|
atime: FileTime,
|
||||||
|
mtime: FileTime,
|
||||||
|
symlink_nofollow: bool,
|
||||||
|
) -> Result<()> {
|
||||||
|
use crate::sys::unix::filetime::to_timespec;
|
||||||
|
use std::ffi::CString;
|
||||||
|
use std::os::unix::prelude::*;
|
||||||
|
|
||||||
|
let flags = if symlink_nofollow {
|
||||||
|
libc::AT_SYMLINK_NOFOLLOW
|
||||||
|
} else {
|
||||||
|
0
|
||||||
|
};
|
||||||
|
let p = CString::new(path.as_bytes())?;
|
||||||
|
let times = [to_timespec(&atime)?, to_timespec(&mtime)?];
|
||||||
|
let rc = unsafe { libc::utimensat(dirfd.as_raw_fd(), p.as_ptr(), times.as_ptr(), flags) };
|
||||||
|
if rc == 0 {
|
||||||
|
Ok(())
|
||||||
|
} else {
|
||||||
|
Err(io::Error::last_os_error().into())
|
||||||
|
}
|
||||||
|
}
|
||||||
7
crates/wasi-common/src/sys/unix/emscripten/mod.rs
Normal file
7
crates/wasi-common/src/sys/unix/emscripten/mod.rs
Normal file
@@ -0,0 +1,7 @@
|
|||||||
|
pub(crate) mod filetime;
|
||||||
|
#[path = "../linux/host_impl.rs"]
|
||||||
|
pub(crate) mod host_impl;
|
||||||
|
#[path = "../linux/hostcalls_impl.rs"]
|
||||||
|
pub(crate) mod hostcalls_impl;
|
||||||
|
#[path = "../linux/oshandle.rs"]
|
||||||
|
pub(crate) mod oshandle;
|
||||||
@@ -1,24 +1,11 @@
|
|||||||
use crate::fdentry::{Descriptor, OsHandleRef};
|
use crate::fdentry::{Descriptor, OsHandleRef};
|
||||||
use crate::{wasi, Error, Result};
|
use crate::{sys::unix::sys_impl, wasi, Error, Result};
|
||||||
use std::fs::File;
|
use std::fs::File;
|
||||||
use std::io;
|
use std::io;
|
||||||
use std::mem::ManuallyDrop;
|
use std::mem::ManuallyDrop;
|
||||||
use std::os::unix::prelude::{AsRawFd, FileTypeExt, FromRawFd, RawFd};
|
use std::os::unix::prelude::{AsRawFd, FileTypeExt, FromRawFd, RawFd};
|
||||||
|
|
||||||
cfg_if::cfg_if! {
|
pub(crate) use sys_impl::oshandle::*;
|
||||||
if #[cfg(target_os = "linux")] {
|
|
||||||
pub(crate) use super::linux::oshandle::*;
|
|
||||||
} else if #[cfg(any(
|
|
||||||
target_os = "macos",
|
|
||||||
target_os = "netbsd",
|
|
||||||
target_os = "freebsd",
|
|
||||||
target_os = "openbsd",
|
|
||||||
target_os = "ios",
|
|
||||||
target_os = "dragonfly"
|
|
||||||
))] {
|
|
||||||
pub(crate) use super::bsd::oshandle::*;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
impl AsRawFd for Descriptor {
|
impl AsRawFd for Descriptor {
|
||||||
fn as_raw_fd(&self) -> RawFd {
|
fn as_raw_fd(&self) -> RawFd {
|
||||||
|
|||||||
@@ -6,21 +6,30 @@
|
|||||||
//! Kudos @alexcrichton!
|
//! Kudos @alexcrichton!
|
||||||
//!
|
//!
|
||||||
//! [filetime]: https://github.com/alexcrichton/filetime
|
//! [filetime]: https://github.com/alexcrichton/filetime
|
||||||
use std::fs::{self, File};
|
use crate::Result;
|
||||||
use std::io;
|
use std::convert::TryInto;
|
||||||
|
|
||||||
|
pub(crate) use super::sys_impl::filetime::*;
|
||||||
|
|
||||||
cfg_if::cfg_if! {
|
cfg_if::cfg_if! {
|
||||||
if #[cfg(target_os = "linux")] {
|
if #[cfg(not(target_os = "emscripten"))] {
|
||||||
pub(crate) use super::linux::filetime::*;
|
fn filetime_to_timespec(ft: &filetime::FileTime) -> Result<libc::timespec> {
|
||||||
} else if #[cfg(any(
|
Ok(
|
||||||
target_os = "macos",
|
libc::timespec {
|
||||||
target_os = "netbsd",
|
tv_sec: ft.seconds(),
|
||||||
target_os = "freebsd",
|
tv_nsec: ft.nanoseconds().try_into()?,
|
||||||
target_os = "openbsd",
|
}
|
||||||
target_os = "ios",
|
)
|
||||||
target_os = "dragonfly"
|
}
|
||||||
))] {
|
} else {
|
||||||
pub(crate) use super::bsd::filetime::*;
|
fn filetime_to_timespec(ft: &filetime::FileTime) -> Result<libc::timespec> {
|
||||||
|
Ok(
|
||||||
|
libc::timespec {
|
||||||
|
tv_sec: ft.seconds().try_into()?,
|
||||||
|
tv_nsec: ft.nanoseconds().try_into()?,
|
||||||
|
}
|
||||||
|
)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -35,91 +44,6 @@ pub(crate) enum FileTime {
|
|||||||
FileTime(filetime::FileTime),
|
FileTime(filetime::FileTime),
|
||||||
}
|
}
|
||||||
|
|
||||||
/// For a provided pair of access and modified `FileTime`s, converts the input to
|
|
||||||
/// `filetime::FileTime` used later in `utimensat` function. For variants `FileTime::Now`
|
|
||||||
/// and `FileTime::Omit`, this function will make two syscalls: either accessing current
|
|
||||||
/// system time, or accessing the file's metadata.
|
|
||||||
///
|
|
||||||
/// The original implementation can be found here: [filetime::unix::get_times].
|
|
||||||
///
|
|
||||||
/// [filetime::unix::get_times]: https://github.com/alexcrichton/filetime/blob/master/src/unix/utimes.rs#L42
|
|
||||||
fn get_times(
|
|
||||||
atime: FileTime,
|
|
||||||
mtime: FileTime,
|
|
||||||
current: impl Fn() -> io::Result<fs::Metadata>,
|
|
||||||
) -> io::Result<(filetime::FileTime, filetime::FileTime)> {
|
|
||||||
use std::time::SystemTime;
|
|
||||||
|
|
||||||
let atime = match atime {
|
|
||||||
FileTime::Now => {
|
|
||||||
let time = SystemTime::now();
|
|
||||||
filetime::FileTime::from_system_time(time)
|
|
||||||
}
|
|
||||||
FileTime::Omit => {
|
|
||||||
let meta = current()?;
|
|
||||||
filetime::FileTime::from_last_access_time(&meta)
|
|
||||||
}
|
|
||||||
FileTime::FileTime(ft) => ft,
|
|
||||||
};
|
|
||||||
|
|
||||||
let mtime = match mtime {
|
|
||||||
FileTime::Now => {
|
|
||||||
let time = SystemTime::now();
|
|
||||||
filetime::FileTime::from_system_time(time)
|
|
||||||
}
|
|
||||||
FileTime::Omit => {
|
|
||||||
let meta = current()?;
|
|
||||||
filetime::FileTime::from_last_modification_time(&meta)
|
|
||||||
}
|
|
||||||
FileTime::FileTime(ft) => ft,
|
|
||||||
};
|
|
||||||
|
|
||||||
Ok((atime, mtime))
|
|
||||||
}
|
|
||||||
|
|
||||||
/// Combines `openat` with `utimes` to emulate `utimensat` on platforms where it is
|
|
||||||
/// not available. The logic for setting file times is based on [filetime::unix::set_file_handles_times].
|
|
||||||
///
|
|
||||||
/// [filetime::unix::set_file_handles_times]: https://github.com/alexcrichton/filetime/blob/master/src/unix/utimes.rs#L24
|
|
||||||
pub(crate) fn utimesat(
|
|
||||||
dirfd: &File,
|
|
||||||
path: &str,
|
|
||||||
atime: FileTime,
|
|
||||||
mtime: FileTime,
|
|
||||||
symlink_nofollow: bool,
|
|
||||||
) -> io::Result<()> {
|
|
||||||
use std::ffi::CString;
|
|
||||||
use std::os::unix::prelude::*;
|
|
||||||
// emulate *at syscall by reading the path from a combination of
|
|
||||||
// (fd, path)
|
|
||||||
let p = CString::new(path.as_bytes())?;
|
|
||||||
let mut flags = libc::O_RDWR;
|
|
||||||
if symlink_nofollow {
|
|
||||||
flags |= libc::O_NOFOLLOW;
|
|
||||||
}
|
|
||||||
let fd = unsafe { libc::openat(dirfd.as_raw_fd(), p.as_ptr(), flags) };
|
|
||||||
let f = unsafe { File::from_raw_fd(fd) };
|
|
||||||
let (atime, mtime) = get_times(atime, mtime, || f.metadata())?;
|
|
||||||
let times = [to_timeval(atime), to_timeval(mtime)];
|
|
||||||
let rc = unsafe { libc::futimes(f.as_raw_fd(), times.as_ptr()) };
|
|
||||||
return if rc == 0 {
|
|
||||||
Ok(())
|
|
||||||
} else {
|
|
||||||
Err(io::Error::last_os_error())
|
|
||||||
};
|
|
||||||
}
|
|
||||||
|
|
||||||
/// Converts `filetime::FileTime` to `libc::timeval`. This function was taken directly from
|
|
||||||
/// [filetime] crate.
|
|
||||||
///
|
|
||||||
/// [filetime]: https://github.com/alexcrichton/filetime/blob/master/src/unix/utimes.rs#L93
|
|
||||||
fn to_timeval(ft: filetime::FileTime) -> libc::timeval {
|
|
||||||
libc::timeval {
|
|
||||||
tv_sec: ft.seconds(),
|
|
||||||
tv_usec: (ft.nanoseconds() / 1000) as libc::suseconds_t,
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
/// Converts `FileTime` to `libc::timespec`. If `FileTime::Now` variant is specified, this
|
/// Converts `FileTime` to `libc::timespec`. If `FileTime::Now` variant is specified, this
|
||||||
/// resolves to `UTIME_NOW` special const, `FileTime::Omit` variant resolves to `UTIME_OMIT`, and
|
/// resolves to `UTIME_NOW` special const, `FileTime::Omit` variant resolves to `UTIME_OMIT`, and
|
||||||
/// `FileTime::FileTime(ft)` where `ft := filetime::FileTime` uses [filetime] crate's original
|
/// `FileTime::FileTime(ft)` where `ft := filetime::FileTime` uses [filetime] crate's original
|
||||||
@@ -127,8 +51,8 @@ fn to_timeval(ft: filetime::FileTime) -> libc::timeval {
|
|||||||
///
|
///
|
||||||
/// [filetime]: https://github.com/alexcrichton/filetime
|
/// [filetime]: https://github.com/alexcrichton/filetime
|
||||||
/// [filetime::unix::to_timespec]: https://github.com/alexcrichton/filetime/blob/master/src/unix/mod.rs#L30
|
/// [filetime::unix::to_timespec]: https://github.com/alexcrichton/filetime/blob/master/src/unix/mod.rs#L30
|
||||||
pub(crate) fn to_timespec(ft: &FileTime) -> libc::timespec {
|
pub(crate) fn to_timespec(ft: &FileTime) -> Result<libc::timespec> {
|
||||||
match ft {
|
let ts = match ft {
|
||||||
FileTime::Now => libc::timespec {
|
FileTime::Now => libc::timespec {
|
||||||
tv_sec: 0,
|
tv_sec: 0,
|
||||||
tv_nsec: UTIME_NOW,
|
tv_nsec: UTIME_NOW,
|
||||||
@@ -137,13 +61,7 @@ pub(crate) fn to_timespec(ft: &FileTime) -> libc::timespec {
|
|||||||
tv_sec: 0,
|
tv_sec: 0,
|
||||||
tv_nsec: UTIME_OMIT,
|
tv_nsec: UTIME_OMIT,
|
||||||
},
|
},
|
||||||
// `filetime::FileTime`'s fields are normalised by definition. `ft.seconds()` return the number
|
FileTime::FileTime(ft) => filetime_to_timespec(ft)?,
|
||||||
// of whole seconds, while `ft.nanoseconds()` returns only fractional part expressed in
|
};
|
||||||
// nanoseconds, as underneath it uses `std::time::Duration::subsec_nanos` to populate the
|
Ok(ts)
|
||||||
// `filetime::FileTime::nanoseconds` field. It is, therefore, OK to do an `as` cast here.
|
|
||||||
FileTime::FileTime(ft) => libc::timespec {
|
|
||||||
tv_sec: ft.seconds(),
|
|
||||||
tv_nsec: ft.nanoseconds() as _,
|
|
||||||
},
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -3,7 +3,7 @@
|
|||||||
#![allow(non_snake_case)]
|
#![allow(non_snake_case)]
|
||||||
#![allow(dead_code)]
|
#![allow(dead_code)]
|
||||||
use crate::host::FileType;
|
use crate::host::FileType;
|
||||||
use crate::{helpers, wasi, Error, Result};
|
use crate::{helpers, sys::unix::sys_impl, wasi, Error, Result};
|
||||||
use std::ffi::OsStr;
|
use std::ffi::OsStr;
|
||||||
use std::os::unix::prelude::OsStrExt;
|
use std::os::unix::prelude::OsStrExt;
|
||||||
use yanix::{
|
use yanix::{
|
||||||
@@ -11,20 +11,7 @@ use yanix::{
|
|||||||
Errno,
|
Errno,
|
||||||
};
|
};
|
||||||
|
|
||||||
cfg_if::cfg_if! {
|
pub(crate) use sys_impl::host_impl::*;
|
||||||
if #[cfg(target_os = "linux")] {
|
|
||||||
pub(crate) use super::linux::host_impl::*;
|
|
||||||
} else if #[cfg(any(
|
|
||||||
target_os = "macos",
|
|
||||||
target_os = "netbsd",
|
|
||||||
target_os = "freebsd",
|
|
||||||
target_os = "openbsd",
|
|
||||||
target_os = "ios",
|
|
||||||
target_os = "dragonfly"
|
|
||||||
))] {
|
|
||||||
pub(crate) use super::bsd::host_impl::*;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
pub(crate) fn errno_from_nix(errno: Errno) -> Error {
|
pub(crate) fn errno_from_nix(errno: Errno) -> Error {
|
||||||
match errno {
|
match errno {
|
||||||
|
|||||||
@@ -3,27 +3,14 @@
|
|||||||
use crate::helpers::systemtime_to_timestamp;
|
use crate::helpers::systemtime_to_timestamp;
|
||||||
use crate::host::{Dirent, FileType};
|
use crate::host::{Dirent, FileType};
|
||||||
use crate::hostcalls_impl::PathGet;
|
use crate::hostcalls_impl::PathGet;
|
||||||
use crate::sys::{fdentry_impl::OsHandle, host_impl};
|
use crate::sys::{fdentry_impl::OsHandle, host_impl, unix::sys_impl};
|
||||||
use crate::{wasi, Error, Result};
|
use crate::{wasi, Error, Result};
|
||||||
use std::convert::TryInto;
|
use std::convert::TryInto;
|
||||||
use std::fs::{File, Metadata};
|
use std::fs::{File, Metadata};
|
||||||
use std::os::unix::fs::FileExt;
|
use std::os::unix::fs::FileExt;
|
||||||
use std::os::unix::prelude::{AsRawFd, FromRawFd};
|
use std::os::unix::prelude::{AsRawFd, FromRawFd};
|
||||||
|
|
||||||
cfg_if::cfg_if! {
|
pub(crate) use sys_impl::hostcalls_impl::*;
|
||||||
if #[cfg(target_os = "linux")] {
|
|
||||||
pub(crate) use super::super::linux::hostcalls_impl::*;
|
|
||||||
} else if #[cfg(any(
|
|
||||||
target_os = "macos",
|
|
||||||
target_os = "netbsd",
|
|
||||||
target_os = "freebsd",
|
|
||||||
target_os = "openbsd",
|
|
||||||
target_os = "ios",
|
|
||||||
target_os = "dragonfly"
|
|
||||||
))] {
|
|
||||||
pub(crate) use super::super::bsd::hostcalls_impl::*;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
pub(crate) fn fd_pread(
|
pub(crate) fn fd_pread(
|
||||||
file: &File,
|
file: &File,
|
||||||
@@ -342,7 +329,7 @@ pub(crate) fn fd_readdir<'a>(
|
|||||||
dir.rewind();
|
dir.rewind();
|
||||||
} else {
|
} else {
|
||||||
log::trace!(" | fd_readdir: doing seekdir to {}", cookie);
|
log::trace!(" | fd_readdir: doing seekdir to {}", cookie);
|
||||||
let loc = unsafe { SeekLoc::from_raw(cookie as i64) };
|
let loc = unsafe { SeekLoc::from_raw(cookie as i64)? };
|
||||||
dir.seek(loc);
|
dir.seek(loc);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -356,7 +343,7 @@ pub(crate) fn fd_readdir<'a>(
|
|||||||
.to_owned(),
|
.to_owned(),
|
||||||
ino: entry.ino(),
|
ino: entry.ino(),
|
||||||
ftype: entry.file_type().into(),
|
ftype: entry.file_type().into(),
|
||||||
cookie: entry.seek_loc().to_raw().try_into()?,
|
cookie: entry.seek_loc()?.to_raw().try_into()?,
|
||||||
})
|
})
|
||||||
}))
|
}))
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
//! This internal module consists of helper types and functions for dealing
|
//! This internal module consists of helper types and functions for dealing
|
||||||
//! with setting the file times specific to Linux.
|
//! with setting the file times specific to Linux.
|
||||||
use super::super::filetime::FileTime;
|
use crate::{sys::unix::filetime::FileTime, Result};
|
||||||
use std::fs::File;
|
use std::fs::File;
|
||||||
use std::io;
|
use std::io;
|
||||||
use std::sync::atomic::{AtomicBool, Ordering::Relaxed};
|
use std::sync::atomic::{AtomicBool, Ordering::Relaxed};
|
||||||
@@ -20,8 +20,8 @@ pub(crate) fn utimensat(
|
|||||||
atime: FileTime,
|
atime: FileTime,
|
||||||
mtime: FileTime,
|
mtime: FileTime,
|
||||||
symlink_nofollow: bool,
|
symlink_nofollow: bool,
|
||||||
) -> io::Result<()> {
|
) -> Result<()> {
|
||||||
use super::super::filetime::{to_timespec, utimesat};
|
use crate::sys::unix::filetime::to_timespec;
|
||||||
use std::ffi::CString;
|
use std::ffi::CString;
|
||||||
use std::os::unix::prelude::*;
|
use std::os::unix::prelude::*;
|
||||||
|
|
||||||
@@ -36,7 +36,7 @@ pub(crate) fn utimensat(
|
|||||||
static INVALID: AtomicBool = AtomicBool::new(false);
|
static INVALID: AtomicBool = AtomicBool::new(false);
|
||||||
if !INVALID.load(Relaxed) {
|
if !INVALID.load(Relaxed) {
|
||||||
let p = CString::new(path.as_bytes())?;
|
let p = CString::new(path.as_bytes())?;
|
||||||
let times = [to_timespec(&atime), to_timespec(&mtime)];
|
let times = [to_timespec(&atime)?, to_timespec(&mtime)?];
|
||||||
let rc = unsafe {
|
let rc = unsafe {
|
||||||
libc::syscall(
|
libc::syscall(
|
||||||
libc::SYS_utimensat,
|
libc::SYS_utimensat,
|
||||||
@@ -53,9 +53,9 @@ pub(crate) fn utimensat(
|
|||||||
if err.raw_os_error() == Some(libc::ENOSYS) {
|
if err.raw_os_error() == Some(libc::ENOSYS) {
|
||||||
INVALID.store(true, Relaxed);
|
INVALID.store(true, Relaxed);
|
||||||
} else {
|
} else {
|
||||||
return Err(err);
|
return Err(err.into());
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
utimesat(dirfd, path, atime, mtime, symlink_nofollow)
|
super::utimesat::utimesat(dirfd, path, atime, mtime, symlink_nofollow)
|
||||||
}
|
}
|
||||||
|
|||||||
11
crates/wasi-common/src/sys/unix/linux/host_impl.rs
Normal file
11
crates/wasi-common/src/sys/unix/linux/host_impl.rs
Normal file
@@ -0,0 +1,11 @@
|
|||||||
|
use crate::{wasi, Result};
|
||||||
|
|
||||||
|
pub(crate) const O_RSYNC: yanix::file::OFlag = yanix::file::OFlag::RSYNC;
|
||||||
|
|
||||||
|
pub(crate) fn stdev_from_nix(dev: libc::dev_t) -> Result<wasi::__wasi_device_t> {
|
||||||
|
Ok(wasi::__wasi_device_t::from(dev))
|
||||||
|
}
|
||||||
|
|
||||||
|
pub(crate) fn stino_from_nix(ino: libc::ino_t) -> Result<wasi::__wasi_inode_t> {
|
||||||
|
Ok(wasi::__wasi_device_t::from(ino))
|
||||||
|
}
|
||||||
@@ -1,17 +1,5 @@
|
|||||||
pub(crate) mod filetime;
|
pub(crate) mod filetime;
|
||||||
|
pub(crate) mod host_impl;
|
||||||
pub(crate) mod hostcalls_impl;
|
pub(crate) mod hostcalls_impl;
|
||||||
pub(crate) mod oshandle;
|
pub(crate) mod oshandle;
|
||||||
|
pub(crate) mod utimesat;
|
||||||
pub(crate) mod host_impl {
|
|
||||||
use crate::{wasi, Result};
|
|
||||||
|
|
||||||
pub(crate) const O_RSYNC: yanix::file::OFlag = yanix::file::OFlag::RSYNC;
|
|
||||||
|
|
||||||
pub(crate) fn stdev_from_nix(dev: libc::dev_t) -> Result<wasi::__wasi_device_t> {
|
|
||||||
Ok(wasi::__wasi_device_t::from(dev))
|
|
||||||
}
|
|
||||||
|
|
||||||
pub(crate) fn stino_from_nix(ino: libc::ino_t) -> Result<wasi::__wasi_inode_t> {
|
|
||||||
Ok(wasi::__wasi_device_t::from(ino))
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|||||||
88
crates/wasi-common/src/sys/unix/linux/utimesat.rs
Normal file
88
crates/wasi-common/src/sys/unix/linux/utimesat.rs
Normal file
@@ -0,0 +1,88 @@
|
|||||||
|
use crate::sys::unix::filetime::FileTime;
|
||||||
|
use crate::Result;
|
||||||
|
use std::{fs, io};
|
||||||
|
|
||||||
|
/// Combines `openat` with `utimes` to emulate `utimensat` on platforms where it is
|
||||||
|
/// not available. The logic for setting file times is based on [filetime::unix::set_file_handles_times].
|
||||||
|
///
|
||||||
|
/// [filetime::unix::set_file_handles_times]: https://github.com/alexcrichton/filetime/blob/master/src/unix/utimes.rs#L24
|
||||||
|
pub(crate) fn utimesat(
|
||||||
|
dirfd: &fs::File,
|
||||||
|
path: &str,
|
||||||
|
atime: FileTime,
|
||||||
|
mtime: FileTime,
|
||||||
|
symlink_nofollow: bool,
|
||||||
|
) -> Result<()> {
|
||||||
|
use std::ffi::CString;
|
||||||
|
use std::os::unix::prelude::*;
|
||||||
|
// emulate *at syscall by reading the path from a combination of
|
||||||
|
// (fd, path)
|
||||||
|
let p = CString::new(path.as_bytes())?;
|
||||||
|
let mut flags = libc::O_RDWR;
|
||||||
|
if symlink_nofollow {
|
||||||
|
flags |= libc::O_NOFOLLOW;
|
||||||
|
}
|
||||||
|
let fd = unsafe { libc::openat(dirfd.as_raw_fd(), p.as_ptr(), flags) };
|
||||||
|
let f = unsafe { fs::File::from_raw_fd(fd) };
|
||||||
|
let (atime, mtime) = get_times(atime, mtime, || f.metadata().map_err(Into::into))?;
|
||||||
|
let times = [to_timeval(atime), to_timeval(mtime)];
|
||||||
|
let rc = unsafe { libc::futimes(f.as_raw_fd(), times.as_ptr()) };
|
||||||
|
if rc == 0 {
|
||||||
|
Ok(())
|
||||||
|
} else {
|
||||||
|
Err(io::Error::last_os_error().into())
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// Converts `filetime::FileTime` to `libc::timeval`. This function was taken directly from
|
||||||
|
/// [filetime] crate.
|
||||||
|
///
|
||||||
|
/// [filetime]: https://github.com/alexcrichton/filetime/blob/master/src/unix/utimes.rs#L93
|
||||||
|
fn to_timeval(ft: filetime::FileTime) -> libc::timeval {
|
||||||
|
libc::timeval {
|
||||||
|
tv_sec: ft.seconds(),
|
||||||
|
tv_usec: (ft.nanoseconds() / 1000) as libc::suseconds_t,
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
/// For a provided pair of access and modified `FileTime`s, converts the input to
|
||||||
|
/// `filetime::FileTime` used later in `utimensat` function. For variants `FileTime::Now`
|
||||||
|
/// and `FileTime::Omit`, this function will make two syscalls: either accessing current
|
||||||
|
/// system time, or accessing the file's metadata.
|
||||||
|
///
|
||||||
|
/// The original implementation can be found here: [filetime::unix::get_times].
|
||||||
|
///
|
||||||
|
/// [filetime::unix::get_times]: https://github.com/alexcrichton/filetime/blob/master/src/unix/utimes.rs#L42
|
||||||
|
fn get_times(
|
||||||
|
atime: FileTime,
|
||||||
|
mtime: FileTime,
|
||||||
|
current: impl Fn() -> Result<fs::Metadata>,
|
||||||
|
) -> Result<(filetime::FileTime, filetime::FileTime)> {
|
||||||
|
use std::time::SystemTime;
|
||||||
|
|
||||||
|
let atime = match atime {
|
||||||
|
FileTime::Now => {
|
||||||
|
let time = SystemTime::now();
|
||||||
|
filetime::FileTime::from_system_time(time)
|
||||||
|
}
|
||||||
|
FileTime::Omit => {
|
||||||
|
let meta = current()?;
|
||||||
|
filetime::FileTime::from_last_access_time(&meta)
|
||||||
|
}
|
||||||
|
FileTime::FileTime(ft) => ft,
|
||||||
|
};
|
||||||
|
|
||||||
|
let mtime = match mtime {
|
||||||
|
FileTime::Now => {
|
||||||
|
let time = SystemTime::now();
|
||||||
|
filetime::FileTime::from_system_time(time)
|
||||||
|
}
|
||||||
|
FileTime::Omit => {
|
||||||
|
let meta = current()?;
|
||||||
|
filetime::FileTime::from_last_modification_time(&meta)
|
||||||
|
}
|
||||||
|
FileTime::FileTime(ft) => ft,
|
||||||
|
};
|
||||||
|
|
||||||
|
Ok((atime, mtime))
|
||||||
|
}
|
||||||
@@ -4,17 +4,23 @@ pub(crate) mod hostcalls_impl;
|
|||||||
|
|
||||||
mod filetime;
|
mod filetime;
|
||||||
|
|
||||||
#[cfg(any(
|
cfg_if::cfg_if! {
|
||||||
target_os = "macos",
|
if #[cfg(target_os = "linux")] {
|
||||||
target_os = "netbsd",
|
mod linux;
|
||||||
target_os = "freebsd",
|
use self::linux as sys_impl;
|
||||||
target_os = "openbsd",
|
} else if #[cfg(target_os = "emscripten")] {
|
||||||
target_os = "ios",
|
mod emscripten;
|
||||||
target_os = "dragonfly"
|
use self::emscripten as sys_impl;
|
||||||
))]
|
} else if #[cfg(any(target_os = "macos",
|
||||||
mod bsd;
|
target_os = "netbsd",
|
||||||
#[cfg(target_os = "linux")]
|
target_os = "freebsd",
|
||||||
mod linux;
|
target_os = "openbsd",
|
||||||
|
target_os = "ios",
|
||||||
|
target_os = "dragonfly"))] {
|
||||||
|
mod bsd;
|
||||||
|
use self::bsd as sys_impl;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
use crate::Result;
|
use crate::Result;
|
||||||
use std::fs::{File, OpenOptions};
|
use std::fs::{File, OpenOptions};
|
||||||
|
|||||||
@@ -84,14 +84,10 @@ impl Entry {
|
|||||||
|
|
||||||
#[cfg(not(target_os = "android"))]
|
#[cfg(not(target_os = "android"))]
|
||||||
#[derive(Clone, Copy, Debug)]
|
#[derive(Clone, Copy, Debug)]
|
||||||
pub struct SeekLoc(libc::c_long);
|
pub struct SeekLoc(pub(crate) libc::c_long);
|
||||||
|
|
||||||
#[cfg(not(target_os = "android"))]
|
#[cfg(not(target_os = "android"))]
|
||||||
impl SeekLoc {
|
impl SeekLoc {
|
||||||
pub unsafe fn from_raw(loc: i64) -> Self {
|
|
||||||
Self(loc.into())
|
|
||||||
}
|
|
||||||
|
|
||||||
pub fn to_raw(&self) -> i64 {
|
pub fn to_raw(&self) -> i64 {
|
||||||
self.0.into()
|
self.0.into()
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -46,7 +46,14 @@ impl EntryExt for Entry {
|
|||||||
self.0.d_ino.into()
|
self.0.d_ino.into()
|
||||||
}
|
}
|
||||||
|
|
||||||
fn seek_loc(&self) -> SeekLoc {
|
fn seek_loc(&self) -> Result<SeekLoc> {
|
||||||
self.0.loc
|
Ok(self.0.loc)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
impl SeekLoc {
|
||||||
|
pub unsafe fn from_raw(loc: i64) -> Result<Self> {
|
||||||
|
let loc = loc.into();
|
||||||
|
Ok(Self(loc))
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
16
crates/wasi-common/yanix/src/sys/emscripten/mod.rs
Normal file
16
crates/wasi-common/yanix/src/sys/emscripten/mod.rs
Normal file
@@ -0,0 +1,16 @@
|
|||||||
|
#[path = "../linux/dir.rs"]
|
||||||
|
pub(crate) mod dir;
|
||||||
|
#[path = "../linux/fadvise.rs"]
|
||||||
|
pub(crate) mod fadvise;
|
||||||
|
#[path = "../linux/file.rs"]
|
||||||
|
pub(crate) mod file;
|
||||||
|
|
||||||
|
use crate::{dir::SeekLoc, Result};
|
||||||
|
use std::convert::TryInto;
|
||||||
|
|
||||||
|
impl SeekLoc {
|
||||||
|
pub unsafe fn from_raw(loc: i64) -> Result<Self> {
|
||||||
|
let loc = loc.try_into()?;
|
||||||
|
Ok(Self(loc))
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -20,7 +20,7 @@ impl EntryExt for Entry {
|
|||||||
self.0.d_ino.into()
|
self.0.d_ino.into()
|
||||||
}
|
}
|
||||||
|
|
||||||
fn seek_loc(&self) -> SeekLoc {
|
fn seek_loc(&self) -> Result<SeekLoc> {
|
||||||
unsafe { SeekLoc::from_raw(self.0.d_off) }
|
unsafe { SeekLoc::from_raw(self.0.d_off) }
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,3 +1,12 @@
|
|||||||
pub(crate) mod dir;
|
pub(crate) mod dir;
|
||||||
pub(crate) mod fadvise;
|
pub(crate) mod fadvise;
|
||||||
pub(crate) mod file;
|
pub(crate) mod file;
|
||||||
|
|
||||||
|
use crate::{dir::SeekLoc, Result};
|
||||||
|
|
||||||
|
impl SeekLoc {
|
||||||
|
pub unsafe fn from_raw(loc: i64) -> Result<Self> {
|
||||||
|
let loc = loc.into();
|
||||||
|
Ok(Self(loc))
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|||||||
@@ -1,19 +1,20 @@
|
|||||||
use crate::dir::SeekLoc;
|
use crate::{dir::SeekLoc, Result};
|
||||||
use cfg_if::cfg_if;
|
use cfg_if::cfg_if;
|
||||||
|
|
||||||
cfg_if! {
|
cfg_if! {
|
||||||
if #[cfg(any(target_os = "linux",
|
if #[cfg(any(target_os = "linux",
|
||||||
target_os = "android",
|
target_os = "android"))] {
|
||||||
target_os = "emscripten"))] {
|
|
||||||
mod linux;
|
mod linux;
|
||||||
pub(crate) use self::linux::*;
|
pub(crate) use self::linux::*;
|
||||||
}
|
} else if #[cfg(target_os = "emscripten")] {
|
||||||
else if #[cfg(any(target_os = "macos",
|
mod emscripten;
|
||||||
target_os = "ios",
|
pub(crate) use self::emscripten::*;
|
||||||
target_os = "freebsd",
|
} else if #[cfg(any(target_os = "macos",
|
||||||
target_os = "netbsd",
|
target_os = "ios",
|
||||||
target_os = "openbsd",
|
target_os = "freebsd",
|
||||||
target_os = "dragonfly"))] {
|
target_os = "netbsd",
|
||||||
|
target_os = "openbsd",
|
||||||
|
target_os = "dragonfly"))] {
|
||||||
mod bsd;
|
mod bsd;
|
||||||
pub(crate) use self::bsd::*;
|
pub(crate) use self::bsd::*;
|
||||||
} else {
|
} else {
|
||||||
@@ -23,5 +24,5 @@ cfg_if! {
|
|||||||
|
|
||||||
pub trait EntryExt {
|
pub trait EntryExt {
|
||||||
fn ino(&self) -> u64;
|
fn ino(&self) -> u64;
|
||||||
fn seek_loc(&self) -> SeekLoc;
|
fn seek_loc(&self) -> Result<SeekLoc>;
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -10,6 +10,8 @@ cargo-fuzz = true
|
|||||||
|
|
||||||
[dependencies]
|
[dependencies]
|
||||||
arbitrary = "0.2.0"
|
arbitrary = "0.2.0"
|
||||||
|
env_logger = "0.7.1"
|
||||||
|
log = "0.4.8"
|
||||||
wasmtime-fuzzing = { path = "../crates/fuzzing", features = ["env_logger"] }
|
wasmtime-fuzzing = { path = "../crates/fuzzing", features = ["env_logger"] }
|
||||||
wasmtime-jit = { path = "../crates/jit" }
|
wasmtime-jit = { path = "../crates/jit" }
|
||||||
libfuzzer-sys = { git = "https://github.com/rust-fuzz/libfuzzer-sys.git" }
|
libfuzzer-sys = { git = "https://github.com/rust-fuzz/libfuzzer-sys.git" }
|
||||||
@@ -29,3 +31,7 @@ path = "fuzz_targets/instantiate.rs"
|
|||||||
[[bin]]
|
[[bin]]
|
||||||
name = "instantiate_translated"
|
name = "instantiate_translated"
|
||||||
path = "fuzz_targets/instantiate_translated.rs"
|
path = "fuzz_targets/instantiate_translated.rs"
|
||||||
|
|
||||||
|
[[bin]]
|
||||||
|
name = "api_calls"
|
||||||
|
path = "fuzz_targets/api_calls.rs"
|
||||||
|
|||||||
27
fuzz/fuzz_targets/api_calls.rs
Executable file
27
fuzz/fuzz_targets/api_calls.rs
Executable file
@@ -0,0 +1,27 @@
|
|||||||
|
#![no_main]
|
||||||
|
|
||||||
|
use libfuzzer_sys::fuzz_target;
|
||||||
|
use std::sync::Once;
|
||||||
|
use wasmtime_fuzzing::{generators::api::ApiCalls, oracles};
|
||||||
|
|
||||||
|
fuzz_target!(|api: ApiCalls| {
|
||||||
|
static INIT_LOGGING: Once = Once::new();
|
||||||
|
INIT_LOGGING.call_once(|| env_logger::init());
|
||||||
|
|
||||||
|
log::debug!(
|
||||||
|
"If this fuzz test fails, here is a regression tests:
|
||||||
|
```
|
||||||
|
#[test]
|
||||||
|
fn my_regression_test() {{
|
||||||
|
use wasmtime_fuzzing::generators::{{
|
||||||
|
api::{{ApiCall::*, ApiCalls}},
|
||||||
|
WasmOptTtf,
|
||||||
|
}};
|
||||||
|
wasmtime_fuzzing::oracles::make_api_calls({:#?});
|
||||||
|
}}
|
||||||
|
```",
|
||||||
|
api
|
||||||
|
);
|
||||||
|
|
||||||
|
oracles::make_api_calls(api);
|
||||||
|
});
|
||||||
Reference in New Issue
Block a user