15c68f2cc1
* Moves CodeMemory, VMInterrupts and SignatureRegistry from Compiler * CompiledModule holds CodeMemory and GdbJitImageRegistration * Store keeps track of its JIT code * Makes "jit_int.rs" stuff Send+Sync * Adds the threads example.
39 lines
1.3 KiB
Rust
39 lines
1.3 KiB
Rust
//! Small example of how you can interrupt the execution of a wasm module to
|
|
//! ensure that it doesn't run for too long.
|
|
|
|
// You can execute this example with `cargo run --example interrupt`
|
|
|
|
use anyhow::Result;
|
|
use wasmtime::*;
|
|
|
|
fn main() -> Result<()> {
|
|
// Enable interruptable code via `Config` and then create an interrupt
|
|
// handle which we'll use later to interrupt running code.
|
|
let engine = Engine::new(Config::new().interruptable(true));
|
|
let store = Store::new(&engine);
|
|
let interrupt_handle = store.interrupt_handle()?;
|
|
|
|
// Compile and instantiate a small example with an infinite loop.
|
|
let module = Module::from_file(&engine, "examples/interrupt.wat")?;
|
|
let instance = Instance::new(&store, &module, &[])?;
|
|
let run = instance
|
|
.get_func("run")
|
|
.ok_or(anyhow::format_err!("failed to find `run` function export"))?
|
|
.get0::<()>()?;
|
|
|
|
// Spin up a thread to send us an interrupt in a second
|
|
std::thread::spawn(move || {
|
|
std::thread::sleep(std::time::Duration::from_secs(1));
|
|
println!("Interrupting!");
|
|
interrupt_handle.interrupt();
|
|
});
|
|
|
|
println!("Entering infinite loop ...");
|
|
let trap = run().unwrap_err();
|
|
|
|
println!("trap received...");
|
|
assert!(trap.to_string().contains("wasm trap: interrupt"));
|
|
|
|
Ok(())
|
|
}
|