mirror of
https://github.com/tendermint/tendermint.git
synced 2026-02-04 11:02:06 +00:00
8fd66a6e8d
## NOTE: this pr exclusively runs commands from the makefile found here This PR ONLY runs `make format` ... then `make mockery` Its purpose is to ensure that the review scope of other PR's, which changed .go files and thus triggered the linter that only runs conditionally, have smaller review scopes, and should be merged before: https://github.com/tendermint/tendermint/pull/9738 https://github.com/tendermint/tendermint/pull/9739 https://github.com/tendermint/tendermint/pull/9742 --- #### PR checklist - [x] Tests written/updated, or no tests needed - [x] `CHANGELOG_PENDING.md` updated, or no changelog entry needed - [x] Updated relevant documentation (`docs/`) and code comments, or no documentation updates needed
126 lines
3.1 KiB
Go
126 lines
3.1 KiB
Go
package report_test
|
|
|
|
import (
|
|
"testing"
|
|
"time"
|
|
|
|
"github.com/google/uuid"
|
|
"google.golang.org/protobuf/types/known/timestamppb"
|
|
|
|
"github.com/tendermint/tendermint/test/loadtime/payload"
|
|
"github.com/tendermint/tendermint/test/loadtime/report"
|
|
"github.com/tendermint/tendermint/types"
|
|
)
|
|
|
|
type mockBlockStore struct {
|
|
base int64
|
|
blocks []*types.Block
|
|
}
|
|
|
|
func (m *mockBlockStore) Height() int64 {
|
|
return m.base + int64(len(m.blocks))
|
|
}
|
|
|
|
func (m *mockBlockStore) Base() int64 {
|
|
return m.base
|
|
}
|
|
|
|
func (m *mockBlockStore) LoadBlock(i int64) *types.Block {
|
|
return m.blocks[i-m.base]
|
|
}
|
|
|
|
func TestGenerateReport(t *testing.T) {
|
|
t1 := time.Now()
|
|
u := [16]byte(uuid.New())
|
|
b1, err := payload.NewBytes(&payload.Payload{
|
|
Id: u[:],
|
|
Time: timestamppb.New(t1.Add(-10 * time.Second)),
|
|
Size: 1024,
|
|
})
|
|
if err != nil {
|
|
t.Fatalf("generating payload %s", err)
|
|
}
|
|
b2, err := payload.NewBytes(&payload.Payload{
|
|
Id: u[:],
|
|
Time: timestamppb.New(t1.Add(-4 * time.Second)),
|
|
Size: 1024,
|
|
})
|
|
if err != nil {
|
|
t.Fatalf("generating payload %s", err)
|
|
}
|
|
b3, err := payload.NewBytes(&payload.Payload{
|
|
Id: u[:],
|
|
Time: timestamppb.New(t1.Add(2 * time.Second)),
|
|
Size: 1024,
|
|
})
|
|
t2 := t1.Add(time.Second)
|
|
if err != nil {
|
|
t.Fatalf("generating payload %s", err)
|
|
}
|
|
s := &mockBlockStore{
|
|
blocks: []*types.Block{
|
|
{
|
|
Data: types.Data{
|
|
Txs: []types.Tx{b1, b2},
|
|
},
|
|
},
|
|
{
|
|
// The timestamp from block H+1 is used to calculate the
|
|
// latency for the transactions in block H.
|
|
Header: types.Header{
|
|
Time: t1,
|
|
},
|
|
Data: types.Data{
|
|
Txs: []types.Tx{[]byte("error")},
|
|
},
|
|
},
|
|
{
|
|
Data: types.Data{
|
|
Txs: []types.Tx{b3, b3},
|
|
},
|
|
},
|
|
{
|
|
Header: types.Header{
|
|
Time: t2,
|
|
},
|
|
Data: types.Data{
|
|
Txs: []types.Tx{},
|
|
},
|
|
},
|
|
},
|
|
}
|
|
rs, err := report.GenerateFromBlockStore(s)
|
|
if err != nil {
|
|
t.Fatalf("generating report %s", err)
|
|
}
|
|
if rs.ErrorCount() != 1 {
|
|
t.Fatalf("ErrorCount did not match expected. Expected %d but contained %d", 1, rs.ErrorCount())
|
|
}
|
|
rl := rs.List()
|
|
if len(rl) != 1 {
|
|
t.Fatalf("number of reports did not match expected. Expected %d but contained %d", 1, len(rl))
|
|
}
|
|
r := rl[0]
|
|
if len(r.All) != 4 {
|
|
t.Fatalf("report contained different number of data points from expected. Expected %d but contained %d", 4, len(r.All))
|
|
}
|
|
if r.NegativeCount != 2 {
|
|
t.Fatalf("NegativeCount did not match expected. Expected %d but contained %d", 2, r.NegativeCount)
|
|
}
|
|
if r.Avg != 3*time.Second {
|
|
t.Fatalf("Avg did not match expected. Expected %s but contained %s", 3*time.Second, r.Avg)
|
|
}
|
|
if r.Min != -time.Second {
|
|
t.Fatalf("Min did not match expected. Expected %s but contained %s", time.Second, r.Min)
|
|
}
|
|
if r.Max != 10*time.Second {
|
|
t.Fatalf("Max did not match expected. Expected %s but contained %s", 10*time.Second, r.Max)
|
|
}
|
|
// Verified using online standard deviation calculator:
|
|
// https://www.calculator.net/standard-deviation-calculator.html?numberinputs=10%2C+4%2C+-1%2C+-1&ctype=s&x=45&y=12
|
|
expectedStdDev := 5228129047 * time.Nanosecond
|
|
if r.StdDev != expectedStdDev {
|
|
t.Fatalf("StdDev did not match expected. Expected %s but contained %s", expectedStdDev, r.StdDev)
|
|
}
|
|
}
|