mirrors/tendermint
1
0
Fork 0
mirror of https://github.com/tendermint/tendermint.git synced 2026-01-05 04:55:18 +00:00
Code Issues Packages Projects Releases Wiki Activity

cleanup: test fixup after refactor

Browse Source
This commit is contained in:
William Banfield
2022-10-24 16:16:28 -04:00
parent d4fcfa127b
commit 60373be5ed
3 changed files with 9 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
p2p/peer_test.go
View File

@@ -4,6 +4,8 @@ import (
"fmt"
golog "log"
"net"
"reflect"
"sync"
"testing"
"time"
@@ -98,8 +100,12 @@ func createOutboundPeerAndPerformHandshake(
if err != nil {
return nil, err
}
mlc := &metricsLabelCache{
mtx: &sync.RWMutex{},
messageLabelNames: make(map[reflect.Type]string),
}
p := newPeer(pc, mConfig, peerNodeInfo, reactorsByCh, msgTypeByChID, chDescs, func(p Peer, r interface{}) {})
p := newPeer(pc, mConfig, peerNodeInfo, reactorsByCh, msgTypeByChID, chDescs, func(p Peer, r interface{}) {}, mlc)
p.SetLogger(log.TestingLogger().With("peer", addr))
return p, nil
}

3
p2p/pex/pex_reactor_test.go
View File

@@ -697,8 +697,7 @@ func TestPexVectors(t *testing.T) {
for _, tc := range testCases {
tc := tc
w, err := tc.msg.(p2p.Wrapper).Wrap()
require.NoError(t, err)
w := tc.msg.(p2p.Wrapper).Wrap()
bz, err := proto.Marshal(w)
require.NoError(t, err)

3
statesync/messages_test.go
View File

@@ -100,8 +100,7 @@ func TestStateSyncVectors(t *testing.T) {
for _, tc := range testCases {
tc := tc
w, err := tc.msg.(p2p.Wrapper).Wrap()
require.NoError(t, err)
w := tc.msg.(p2p.Wrapper).Wrap()
bz, err := proto.Marshal(w)
require.NoError(t, err)