Files
wazero/tests/bench/bench_test.go
Takeshi Yoneda 4cd4d8a590 Fix broken base64 bench (#456)
Signed-off-by: Takeshi Yoneda <takeshi@tetrate.io>
2022-04-13 11:02:26 +08:00

158 lines
4.0 KiB
Go

package bench
import (
_ "embed"
"fmt"
"math/rand"
"runtime"
"testing"
"github.com/tetratelabs/wazero"
"github.com/tetratelabs/wazero/api"
"github.com/tetratelabs/wazero/wasi"
)
// caseWasm was compiled from TinyGo testdata/case.go
//go:embed testdata/case.wasm
var caseWasm []byte
func BenchmarkEngines(b *testing.B) {
b.Run("interpreter", func(b *testing.B) {
m := instantiateHostFunctionModuleWithEngine(b, wazero.NewRuntimeConfigInterpreter())
defer m.Close()
runAllBenches(b, m)
})
if runtime.GOARCH == "amd64" || runtime.GOARCH == "arm64" {
b.Run("jit", func(b *testing.B) {
m := instantiateHostFunctionModuleWithEngine(b, wazero.NewRuntimeConfigJIT())
defer m.Close()
runAllBenches(b, m)
})
}
}
func runAllBenches(b *testing.B, m api.Module) {
runBase64Benches(b, m)
runFibBenches(b, m)
runStringManipulationBenches(b, m)
runReverseArrayBenches(b, m)
runRandomMatMul(b, m)
}
func runBase64Benches(b *testing.B, m api.Module) {
base64 := m.ExportedFunction("base64")
for _, numPerExec := range []int{5, 100, 10000} {
numPerExec := uint64(numPerExec)
b.ResetTimer()
b.Run(fmt.Sprintf("base64_%d_per_exec", numPerExec), func(b *testing.B) {
for i := 0; i < b.N; i++ {
if _, err := base64.Call(nil, numPerExec); err != nil {
b.Fatal(err)
}
}
})
}
}
func runFibBenches(b *testing.B, m api.Module) {
fibonacci := m.ExportedFunction("fibonacci")
for _, num := range []int{5, 10, 20, 30} {
num := uint64(num)
b.ResetTimer()
b.Run(fmt.Sprintf("fib_for_%d", num), func(b *testing.B) {
for i := 0; i < b.N; i++ {
if _, err := fibonacci.Call(nil, num); err != nil {
b.Fatal(err)
}
}
})
}
}
func runStringManipulationBenches(b *testing.B, m api.Module) {
stringManipulation := m.ExportedFunction("string_manipulation")
for _, initialSize := range []int{50, 100, 1000} {
initialSize := uint64(initialSize)
b.ResetTimer()
b.Run(fmt.Sprintf("string_manipulation_size_%d", initialSize), func(b *testing.B) {
for i := 0; i < b.N; i++ {
if _, err := stringManipulation.Call(nil, initialSize); err != nil {
b.Fatal(err)
}
}
})
}
}
func runReverseArrayBenches(b *testing.B, m api.Module) {
reverseArray := m.ExportedFunction("reverse_array")
for _, arraySize := range []int{500, 1000, 10000} {
arraySize := uint64(arraySize)
b.ResetTimer()
b.Run(fmt.Sprintf("reverse_array_size_%d", arraySize), func(b *testing.B) {
for i := 0; i < b.N; i++ {
if _, err := reverseArray.Call(nil, arraySize); err != nil {
b.Fatal(err)
}
}
})
}
}
func runRandomMatMul(b *testing.B, m api.Module) {
randomMatMul := m.ExportedFunction("random_mat_mul")
for _, matrixSize := range []int{5, 10, 20} {
matrixSize := uint64(matrixSize)
b.ResetTimer()
b.Run(fmt.Sprintf("random_mat_mul_size_%d", matrixSize), func(b *testing.B) {
for i := 0; i < b.N; i++ {
if _, err := randomMatMul.Call(nil, matrixSize); err != nil {
b.Fatal(err)
}
}
})
}
}
func instantiateHostFunctionModuleWithEngine(b *testing.B, engine *wazero.RuntimeConfig) api.Module {
getRandomString := func(ctx api.Module, retBufPtr uint32, retBufSize uint32) {
results, err := ctx.ExportedFunction("allocate_buffer").Call(ctx, 10)
if err != nil {
b.Fatal(err)
}
offset := uint32(results[0])
ctx.Memory().WriteUint32Le(retBufPtr, offset)
ctx.Memory().WriteUint32Le(retBufSize, 10)
b := make([]byte, 10)
_, _ = rand.Read(b)
ctx.Memory().Write(offset, b)
}
r := wazero.NewRuntimeWithConfig(engine)
_, err := r.NewModuleBuilder("env").ExportFunction("get_random_string", getRandomString).Instantiate()
if err != nil {
b.Fatal(err)
}
// Note: host_func.go doesn't directly use WASI, but TinyGo needs to be initialized as a WASI Command.
// Add WASI to satisfy import tests
_, err = wasi.InstantiateSnapshotPreview1(r)
if err != nil {
b.Fatal(err)
}
// InstantiateModuleFromCode runs the "_start" function which is what TinyGo compiles "main" to.
m, err := r.InstantiateModuleFromCode(caseWasm)
if err != nil {
b.Fatal(err)
}
return m
}