mleku/wasmd
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

More bank/cw20 benchmarks (#651)

Browse Source 
* Add blocks of 1000 tx

* Increase Block.MasGas for tests/benchmarks

* Add huge initialization
This commit is contained in:
Ethan Frey
2021-10-19 10:06:52 +02:00
committed by GitHub
parent d82a0b94d2
commit 2abbc00baf
3 changed files with 111 additions and 86 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
benchmarks/app_test.go
View File

@@ -140,13 +140,13 @@ func InitializeWasmApp(b testing.TB, db dbm.DB, numAccounts int) AppInfo {
}
initialBalances[i] = balance{
Address: acct,
Amount: 1000000000,
Amount: 1000000000,
}
}
init := cw20InitMsg{
Name: "Cash Money",
Symbol: "CASH",
Decimals: 2,
Name: "Cash Money",
Symbol: "CASH",
Decimals: 2,
InitialBalances: initialBalances,
}
initBz, err := json.Marshal(init)

184
benchmarks/bench_test.go
View File

@@ -19,6 +19,110 @@ import (
wasmtypes "github.com/CosmWasm/wasmd/x/wasm/types"
)
func BenchmarkTxSending(b *testing.B) {
cases := map[string]struct {
db func(*testing.B) dbm.DB
txBuilder func(*testing.B, *AppInfo) []sdk.Tx
blockSize int
numAccounts int
}{
"basic send - memdb": {
db: buildMemDB,
blockSize: 20,
txBuilder: buildTxFromMsg(bankSendMsg),
numAccounts: 50,
},
"cw20 transfer - memdb": {
db: buildMemDB,
blockSize: 20,
txBuilder: buildTxFromMsg(cw20TransferMsg),
numAccounts: 50,
},
"basic send - leveldb": {
db: buildLevelDB,
blockSize: 20,
txBuilder: buildTxFromMsg(bankSendMsg),
numAccounts: 50,
},
"cw20 transfer - leveldb": {
db: buildLevelDB,
blockSize: 20,
txBuilder: buildTxFromMsg(cw20TransferMsg),
numAccounts: 50,
},
"basic send - leveldb - 8k accounts": {
db: buildLevelDB,
blockSize: 20,
txBuilder: buildTxFromMsg(bankSendMsg),
numAccounts: 8000,
},
"cw20 transfer - leveldb - 8k accounts": {
db: buildLevelDB,
blockSize: 20,
txBuilder: buildTxFromMsg(cw20TransferMsg),
numAccounts: 8000,
},
"basic send - leveldb - 8k accounts - huge blocks": {
db: buildLevelDB,
blockSize: 1000,
txBuilder: buildTxFromMsg(bankSendMsg),
numAccounts: 8000,
},
"cw20 transfer - leveldb - 8k accounts - huge blocks": {
db: buildLevelDB,
blockSize: 1000,
txBuilder: buildTxFromMsg(cw20TransferMsg),
numAccounts: 8000,
},
"basic send - leveldb - 80k accounts": {
db: buildLevelDB,
blockSize: 20,
txBuilder: buildTxFromMsg(bankSendMsg),
numAccounts: 80000,
},
"cw20 transfer - leveldb - 80k accounts": {
db: buildLevelDB,
blockSize: 20,
txBuilder: buildTxFromMsg(cw20TransferMsg),
numAccounts: 80000,
},
}
for name, tc := range cases {
b.Run(name, func(b *testing.B) {
db := tc.db(b)
appInfo := InitializeWasmApp(b, db, tc.numAccounts)
txs := tc.txBuilder(b, &appInfo)
// number of Tx per block for the benchmarks
blockSize := tc.blockSize
height := int64(3)
txEncoder := appInfo.TxConfig.TxEncoder()
b.ResetTimer()
for i := 0; i < b.N/blockSize; i++ {
appInfo.App.BeginBlock(abci.RequestBeginBlock{Header: tmproto.Header{Height: height, Time: time.Now()}})
for j := 0; j < blockSize; j++ {
idx := i*blockSize + j
_, _, err := appInfo.App.Check(txEncoder, txs[idx])
if err != nil {
panic("something is broken in checking transaction")
}
_, _, err = appInfo.App.Deliver(txEncoder, txs[idx])
require.NoError(b, err)
}
appInfo.App.EndBlock(abci.RequestEndBlock{Height: height})
appInfo.App.Commit()
height++
}
})
}
}
func bankSendMsg(info *AppInfo) ([]sdk.Msg, error) {
// Precompute all txs
rcpt := sdk.AccAddress(secp256k1.GenPrivKey().PubKey().Address())
@@ -61,83 +165,3 @@ func buildLevelDB(b *testing.B) dbm.DB {
require.NoError(b, err)
return levelDB
}
func BenchmarkTxSending(b *testing.B) {
cases := map[string]struct {
db func(*testing.B) dbm.DB
txBuilder func(*testing.B, *AppInfo) []sdk.Tx
blockSize int
numAccounts int
}{
"basic send - memdb": {
db: buildMemDB,
blockSize: 20,
txBuilder: buildTxFromMsg(bankSendMsg),
numAccounts: 50,
},
"cw20 transfer - memdb": {
db: buildMemDB,
blockSize: 20,
txBuilder: buildTxFromMsg(cw20TransferMsg),
numAccounts: 50,
},
"basic send - leveldb": {
db: buildLevelDB,
blockSize: 20,
txBuilder: buildTxFromMsg(bankSendMsg),
numAccounts: 50,
},
"cw20 transfer - leveldb": {
db: buildLevelDB,
blockSize: 20,
txBuilder: buildTxFromMsg(cw20TransferMsg),
numAccounts: 50,
},
"basic send - leveldb - 8k accounts": {
db: buildLevelDB,
blockSize: 20,
txBuilder: buildTxFromMsg(bankSendMsg),
numAccounts: 8000,
},
"cw20 transfer - leveldb - 8k accounts": {
db: buildLevelDB,
blockSize: 20,
txBuilder: buildTxFromMsg(cw20TransferMsg),
numAccounts: 8000,
},
}
for name, tc := range cases {
b.Run(name, func(b *testing.B) {
db := tc.db(b)
appInfo := InitializeWasmApp(b, db, tc.numAccounts)
txs := tc.txBuilder(b, &appInfo)
// number of Tx per block for the benchmarks
blockSize := tc.blockSize
height := int64(3)
txEncoder := appInfo.TxConfig.TxEncoder()
b.ResetTimer()
for i := 0; i < b.N/blockSize; i++ {
appInfo.App.BeginBlock(abci.RequestBeginBlock{Header: tmproto.Header{Height: height, Time: time.Now()}})
for j := 0; j < blockSize; j++ {
idx := i*blockSize + j
_, _, err := appInfo.App.Check(txEncoder, txs[idx])
if err != nil {
panic("something is broken in checking transaction")
}
_, _, err = appInfo.App.Deliver(txEncoder, txs[idx])
require.NoError(b, err)
}
appInfo.App.EndBlock(abci.RequestEndBlock{Height: height})
appInfo.App.Commit()
height++
}
})
}
}