Skip to content

Commit

Permalink
Try #536:
Browse files Browse the repository at this point in the history
  • Loading branch information
bors[bot] committed Jul 8, 2019
2 parents c8a15ed + f45d523 commit b7ca009
Show file tree
Hide file tree
Showing 6 changed files with 65 additions and 43 deletions.
1 change: 1 addition & 0 deletions CHANGELOG.md
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,7 @@ Blocks of changes will separated by version increments.

## **[Unreleased]**
## 0.5.4
- [#536](https://github.com/wasmerio/wasmer/pull/536) Update cache to use compiler backend name in cache key
- [#529](https://github.com/wasmerio/wasmer/pull/529) Updates the Wasm Interface library, which is used by wapm, with bug fixes and error message improvements

## 0.5.3
Expand Down
50 changes: 50 additions & 0 deletions lib/runtime-core/src/backend.rs
Original file line number Diff line number Diff line change
Expand Up @@ -29,6 +29,56 @@ pub enum Backend {
LLVM,
}

impl Backend {
pub fn variants() -> &'static [&'static str] {
&[
"cranelift",
#[cfg(feature = "backend:singlepass")]
"singlepass",
#[cfg(feature = "backend:llvm")]
"llvm",
]
}

/// stable string representation of the backend
/// can be used as part of a cache key, for example
pub fn to_string(&self) -> &'static str {
match self {
Backend::Cranelift => "cranelift",
Backend::Singlepass => "singlepass",
Backend::LLVM => "llvm",
}
}
}

impl std::str::FromStr for Backend {
type Err = String;
fn from_str(s: &str) -> Result<Backend, String> {
match s.to_lowercase().as_str() {
"singlepass" => Ok(Backend::Singlepass),
"cranelift" => Ok(Backend::Cranelift),
"llvm" => Ok(Backend::LLVM),
_ => Err(format!("The backend {} doesn't exist", s)),
}
}
}

#[cfg(test)]
mod backend_test {
use super::*;
use std::str::FromStr;

#[test]
fn str_repr_matches() {
// if this test breaks, think hard about why it's breaking
// can we avoid having these be different?

for &backend in &[Backend::Cranelift, Backend::LLVM, Backend::Singlepass] {
assert_eq!(backend, Backend::from_str(backend.to_string()).unwrap());
}
}
}

/// This type cannot be constructed from
/// outside the runtime crate.
pub struct Token {
Expand Down
4 changes: 3 additions & 1 deletion lib/runtime-core/src/cache.rs
Original file line number Diff line number Diff line change
@@ -1,4 +1,5 @@
use crate::{
backend::Backend,
module::{Module, ModuleInfo},
sys::Memory,
};
Expand Down Expand Up @@ -41,12 +42,13 @@ impl WasmHash {
/// # Note:
/// This does no verification that the supplied data
/// is, in fact, a wasm module.
pub fn generate(wasm: &[u8]) -> Self {
pub fn generate(wasm: &[u8], backend: Backend) -> Self {
let mut first_part = [0u8; 32];
let mut second_part = [0u8; 32];

let mut state = blake2bp::State::new();
state.update(wasm);
state.update(backend.to_string().as_bytes());

let hasher = state.finalize();
let generic_array = hasher.as_bytes();
Expand Down
7 changes: 5 additions & 2 deletions lib/runtime/benches/nginx.rs
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,7 @@ use wasmer_runtime::{
cache::{Cache, FileSystemCache, WasmHash},
compile, validate,
};
use wasmer_runtime_core::backend::Backend;

static NGINX_WASM: &'static [u8] = include_bytes!("../../../examples/nginx/nginx.wasm");

Expand All @@ -18,7 +19,9 @@ fn load_module(hash: WasmHash, cache: &impl Cache) {
}

fn hashing_benchmark(c: &mut Criterion) {
c.bench_function("nginx HASH", |b| b.iter(|| WasmHash::generate(NGINX_WASM)));
c.bench_function("nginx HASH", |b| {
b.iter(|| WasmHash::generate(NGINX_WASM, Backend::Cranelift))
});
}

fn validate_benchmark(c: &mut Criterion) {
Expand All @@ -36,7 +39,7 @@ fn load_benchmark(c: &mut Criterion) {
FileSystemCache::new(tempdir.path()).expect("unable to create file system cache")
};
let module = compile(NGINX_WASM).unwrap();
let wasm_hash = WasmHash::generate(NGINX_WASM);
let wasm_hash = WasmHash::generate(NGINX_WASM, Backend::Cranelift);
cache
.store(wasm_hash, module)
.expect("unable to store into cache");
Expand Down
6 changes: 4 additions & 2 deletions lib/runtime/src/cache.rs
Original file line number Diff line number Diff line change
Expand Up @@ -20,6 +20,7 @@ pub use wasmer_runtime_core::cache::{Artifact, Cache, WasmHash, WASMER_VERSION_H
///
/// ```rust
/// use wasmer_runtime::cache::{Cache, FileSystemCache, WasmHash};
/// use wasmer_runtime_core::backend::Backend;
///
/// # use wasmer_runtime::{Module, error::CacheError};
/// fn store_module(module: Module) -> Result<Module, CacheError> {
Expand All @@ -28,7 +29,7 @@ pub use wasmer_runtime_core::cache::{Artifact, Cache, WasmHash, WASMER_VERSION_H
/// // corrupted or tampered with.
/// let mut fs_cache = unsafe { FileSystemCache::new("some/directory/goes/here")? };
/// // Compute a key for a given WebAssembly binary
/// let key = WasmHash::generate(&[]);
/// let key = WasmHash::generate(&[], Backend::Cranelift);
/// // Store a module into the cache given a key
/// fs_cache.store(key, module.clone())?;
/// Ok(module)
Expand Down Expand Up @@ -119,6 +120,7 @@ mod tests {

use super::*;
use std::env;
use wasmer_runtime_core::backend::Backend;

#[test]
fn test_file_system_cache_run() {
Expand Down Expand Up @@ -147,7 +149,7 @@ mod tests {
.unwrap()
};
// store module
let key = WasmHash::generate(&wasm);
let key = WasmHash::generate(&wasm, Backend::Cranelift);
fs_cache.store(key, module.clone()).unwrap();

// load module
Expand Down
40 changes: 2 additions & 38 deletions src/bin/wasmer.rs
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@ use wasmer_runtime::{
};
use wasmer_runtime_core::{
self,
backend::{Compiler, CompilerConfig, MemoryBoundCheckMode},
backend::{Backend, Compiler, CompilerConfig, MemoryBoundCheckMode},
loader::{Instance as LoadedInstance, LocalLoader},
};
#[cfg(feature = "backend:singlepass")]
Expand Down Expand Up @@ -153,42 +153,6 @@ impl FromStr for LoaderName {
}
}

#[allow(dead_code)]
#[derive(Debug, Eq, PartialEq)]
enum Backend {
Cranelift,
Singlepass,
LLVM,
}

impl Backend {
pub fn variants() -> &'static [&'static str] {
&[
"cranelift",
#[cfg(feature = "backend:singlepass")]
"singlepass",
#[cfg(feature = "backend:llvm")]
"llvm",
]
}
}

impl FromStr for Backend {
type Err = String;
fn from_str(s: &str) -> Result<Backend, String> {
match s.to_lowercase().as_str() {
"singlepass" => Ok(Backend::Singlepass),
"cranelift" => Ok(Backend::Cranelift),
"llvm" => Ok(Backend::LLVM),
// "llvm" => Err(
// "The LLVM backend option is not enabled by default due to binary size constraints"
// .to_string(),
// ),
_ => Err(format!("The backend {} doesn't exist", s)),
}
}
}

#[derive(Debug, StructOpt)]
enum Cache {
/// Clear the cache
Expand Down Expand Up @@ -388,7 +352,7 @@ fn execute_wasm(options: &Run) -> Result<(), String> {

// We generate a hash for the given binary, so we can use it as key
// for the Filesystem cache
let hash = WasmHash::generate(&wasm_binary);
let hash = WasmHash::generate(&wasm_binary, options.backend);

let wasmer_cache_dir = get_cache_dir();

Expand Down

0 comments on commit b7ca009

Please sign in to comment.