mirror of
https://github.com/tendermint/tendermint.git
synced 2026-09-29 03:05:49 +00:00
Alexander BezobchukandAnton Kaliaev
14fa800773
- Replace the previous intersect call, which was called at each query condition, with a map intersection. - Replace fmt.Sprintf with string() closes: #3076 Benchmarks ``` Old goos: darwin goarch: amd64 pkg: github.com/tendermint/tendermint/state/txindex/kv BenchmarkTxSearch-4 200 103641206 ns/op 7998416 B/op 71171 allocs/op PASS ok github.com/tendermint/tendermint/state/txindex/kv 26.019s New goos: darwin goarch: amd64 pkg: github.com/tendermint/tendermint/state/txindex/kv BenchmarkTxSearch-4 1000 38615024 ns/op 13515226 B/op 166460 allocs/op PASS ok github.com/tendermint/tendermint/state/txindex/kv 53.618s ``` ~62% performance improvement Commits: * Refactor tx search * Add pending changelog entry * Add tx search benchmarking * remove intermediate hashes list also reset timer in BenchmarkTxSearch and fix other benchmark * fix import * Add test cases * Fix searching * Replace fmt.Sprintf with string * Update state/txindex/kv/kv.go Co-Authored-By: Anton Kaliaev <anton.kalyaev@gmail.com> * Rename params * Cleanup * Check error in benchmarks
73 lines
1.7 KiB
Go
73 lines
1.7 KiB
Go
package kv
|
|
|
|
import (
|
|
"crypto/rand"
|
|
"fmt"
|
|
"io/ioutil"
|
|
"testing"
|
|
|
|
abci "github.com/tendermint/tendermint/abci/types"
|
|
cmn "github.com/tendermint/tendermint/libs/common"
|
|
"github.com/tendermint/tendermint/libs/pubsub/query"
|
|
"github.com/tendermint/tendermint/types"
|
|
dbm "github.com/tendermint/tm-db"
|
|
)
|
|
|
|
func BenchmarkTxSearch(b *testing.B) {
|
|
dbDir, err := ioutil.TempDir("", "benchmark_tx_search_test")
|
|
if err != nil {
|
|
b.Errorf("failed to create temporary directory: %s", err)
|
|
}
|
|
|
|
db, err := dbm.NewGoLevelDB("benchmark_tx_search_test", dbDir)
|
|
if err != nil {
|
|
b.Errorf("failed to create database: %s", err)
|
|
}
|
|
|
|
allowedTags := []string{"transfer.address", "transfer.amount"}
|
|
indexer := NewTxIndex(db, IndexTags(allowedTags))
|
|
|
|
for i := 0; i < 35000; i++ {
|
|
events := []abci.Event{
|
|
{
|
|
Type: "transfer",
|
|
Attributes: []cmn.KVPair{
|
|
{Key: []byte("address"), Value: []byte(fmt.Sprintf("address_%d", i%100))},
|
|
{Key: []byte("amount"), Value: []byte("50")},
|
|
},
|
|
},
|
|
}
|
|
|
|
txBz := make([]byte, 8)
|
|
if _, err := rand.Read(txBz); err != nil {
|
|
b.Errorf("failed produce random bytes: %s", err)
|
|
}
|
|
|
|
txResult := &types.TxResult{
|
|
Height: int64(i),
|
|
Index: 0,
|
|
Tx: types.Tx(string(txBz)),
|
|
Result: abci.ResponseDeliverTx{
|
|
Data: []byte{0},
|
|
Code: abci.CodeTypeOK,
|
|
Log: "",
|
|
Events: events,
|
|
},
|
|
}
|
|
|
|
if err := indexer.Index(txResult); err != nil {
|
|
b.Errorf("failed to index tx: %s", err)
|
|
}
|
|
}
|
|
|
|
txQuery := query.MustParse("transfer.address = 'address_43' AND transfer.amount = 50")
|
|
|
|
b.ResetTimer()
|
|
|
|
for i := 0; i < b.N; i++ {
|
|
if _, err := indexer.Search(txQuery); err != nil {
|
|
b.Errorf("failed to query for txs: %s", err)
|
|
}
|
|
}
|
|
}
|