-
Notifications
You must be signed in to change notification settings - Fork 22
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Add wasmer web assembly engine as POC
This adds the wasmer-d submodule and an engine which can run in d at runtime. Currently the Engine is only run in the unit tests in `WasmEngine.d` to experiment with running Web Assembly programs. `dtest=WasmEngine dub test`
- Loading branch information
1 parent
43a2aea
commit 1bc36ac
Showing
10 changed files
with
187 additions
and
2 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
|
|
@@ -60,12 +60,17 @@ jobs: | |
| brew install coreutils libsodium pkg-config | ||
| echo "LIBRARY_PATH=${LD_LIBRARY_PATH-}:/usr/local/lib/" >> $GITHUB_ENV | ||
| echo "PKG_CONFIG_PATH=/usr/local/opt/sqlite/lib/pkgconfig:/usr/local/opt/[email protected]/lib/pkgconfig/" >> $GITHUB_ENV | ||
| env | grep HOME | ||
| curl https://get.wasmer.io -sSfL | WASMER_DIR=${HOME}/.wasmer sh | ||
| echo 'WASMER_DIR=${HOME}/.wasmer' >> $GITHUB_ENV | ||
| - name: '[Linux] Install dependencies & setup environment' | ||
| if: runner.os == 'Linux' | ||
| run: | | ||
| sudo apt-get update | ||
| sudo apt-get install libsodium-dev libsqlite3-dev clang | ||
| curl https://get.wasmer.io -sSfL | WASMER_DIR=${HOME}/.wasmer sh | ||
| echo 'WASMER_DIR=${HOME}/.wasmer' >> $GITHUB_ENV | ||
| - name: '[Windows] Install dependencies & setup environment' | ||
| if: runner.os == 'Windows' | ||
|
|
||
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,155 @@ | ||
| /******************************************************************************* | ||
| Contains the wasmer WebAssembly engine to be used for Trust Contracts. | ||
| The submodule `wasmer-d` provides a `D` wrapper of the `wamser` runtime. | ||
| (https://chances.github.io/wasmer-d/wasmer.html) | ||
| Copyright: | ||
| Copyright (c) 2021 BOS Platform Foundation Korea | ||
| All rights reserved. | ||
| License: | ||
| MIT License. See LICENSE for details. | ||
| *******************************************************************************/ | ||
|
|
||
| module agora.node.WasmEngine; | ||
|
|
||
| import agora.utils.Log; | ||
|
|
||
| mixin AddLogger!(); | ||
|
|
||
| /// Ditto | ||
| public class WasmEngine | ||
| { | ||
| import wasmer; | ||
|
|
||
| /// The JIT engine for executing WebAssembly Programs (WASM) | ||
| Engine engine; | ||
|
|
||
| /// The global state that can be manipulated by WebAssembly programs | ||
| /// https://webassembly.github.io/spec/core/exec/runtime.html#syntax-store | ||
| Store store; | ||
|
|
||
| public void start () | ||
| { | ||
| log.info("Starting WasmEngine"); | ||
| engine = new Engine(); | ||
| store = new Store(engine); | ||
| log.info("Started WasmEngine"); | ||
| } | ||
|
|
||
| public void stop () | ||
| { | ||
| log.info("Stopping WasmEngine"); | ||
| destroy(store); | ||
| destroy(engine); | ||
| log.info("Stopped WasmEngine"); | ||
| } | ||
|
|
||
| public void exampleTime () | ||
| { | ||
| log.info("Running {} using WasmEngine", __FUNCTION__); | ||
| const wat_callback_module_time = "(module | ||
| (type $FUNCSIG$ii (func (param i32) (result i32))) | ||
| (import \"env\" \"time\" (func $time (param i32) (result i32))) | ||
| (table 0 anyfunc) | ||
| (memory $0 1) | ||
| (export \"memory\" (memory $0)) | ||
| (export \"main\" (func $main)) | ||
| (func $main (; 1 ;) (result i32) | ||
| (call $time | ||
| (i32.const 0) | ||
| ) | ||
| ) | ||
| )"; | ||
| log.trace("wat (text representation of wasm)"); | ||
| log.trace("=============================="); | ||
| log.trace("{}", wat_callback_module_time); | ||
| log.trace("=============================="); | ||
| auto module_ = Module.from(store, wat_callback_module_time); | ||
| assert(module_.valid, "Error compiling module!"); | ||
|
|
||
| auto print = (Module module_, int value) => | ||
| { | ||
| return value; | ||
| }(); | ||
| auto imports = [new Function(store, module_, print.toDelegate).asExtern]; | ||
| auto instance = module_.instantiate(imports); | ||
| assert(instance.valid, "Could not instantiate module!"); | ||
| auto runFunc = Function.from(instance.exports[1]); | ||
| assert(instance.exports[1].name == "main", "Failed to get the `main` function!"); | ||
| assert(runFunc.valid, "`main` function invalid!"); | ||
| Value[] results; | ||
| assert(runFunc.call(results), "Error calling the `main` function!"); | ||
| assert(results.length == 1, "length of results should be 1!"); | ||
| // assert(results[0].value.of.i32 > 0, "time should be greater than 0"); | ||
| log.info("Used web assembly engine to get time. Result = {}", results[0].value.of.i32); | ||
| destroy(instance); | ||
| destroy(module_); | ||
| } | ||
|
|
||
|
|
||
| public void exampleAdd () | ||
| { | ||
| const wat_callback_module_add = "(module" ~ | ||
| " (func $print (import \"\" \"print\") (param i32) (result i32))" ~ | ||
| " (func (export \"run\") (param $x i32) (param $y i32) (result i32)" ~ | ||
| " (call $print (i32.add (local.get $x) (local.get $y)))" ~ | ||
| " )" ~ | ||
| ")"; | ||
| log.info("Running {} using WasmEngine", __FUNCTION__); | ||
| log.trace("wat (text representation of wasm)"); | ||
| log.trace("=============================="); | ||
| log.trace("{}", wat_callback_module_add); | ||
| log.trace("=============================="); | ||
|
|
||
| auto module_ = Module.from(store, wat_callback_module_add); | ||
| assert(module_.valid, "Error compiling module!"); | ||
|
|
||
| auto print = (Module module_, int value) => | ||
| { | ||
| return value; | ||
| }(); | ||
| auto imports = [new Function(store, module_, print.toDelegate).asExtern]; | ||
| auto instance = module_.instantiate(imports); | ||
| assert(instance.valid, "Could not instantiate module!"); | ||
| auto runFunc = Function.from(instance.exports[0]); | ||
| assert(instance.exports[0].name == "run" && runFunc.valid, "Failed to get the `run` function!"); | ||
|
|
||
| auto three = new Value(3); | ||
| auto four = new Value(4); | ||
| Value[] results; | ||
| assert(runFunc.call([three, four], results), "Error calling the `run` function!"); | ||
| assert(results.length == 1 && results[0].value.of.i32 == 7); | ||
| log.info("Used web assembly engine to add 3 and 4. Result = {}", results[0].value.of.i32); | ||
|
|
||
| destroy(three); | ||
| destroy(four); | ||
| destroy(instance); | ||
| destroy(module_); | ||
| } | ||
| } | ||
|
|
||
| unittest | ||
| { | ||
| import std.stdio; | ||
| import std.format; | ||
|
|
||
| Log.root.level(LogLevel.Trace, true); | ||
| auto output = stdout.lockingTextWriter(); | ||
| try | ||
| { | ||
| auto wasmEngine = new WasmEngine(); | ||
| wasmEngine.start(); | ||
| wasmEngine.exampleAdd(); | ||
| wasmEngine.exampleTime(); | ||
| wasmEngine.stop(); | ||
| } | ||
| catch (Exception e) | ||
| { | ||
| output.formattedWrite("%s", e); | ||
| } | ||
| // print logs of the work thread | ||
| CircularAppender!()().print(output); | ||
| } |