mirror of
https://github.com/tendermint/tendermint.git
synced 2026-02-04 02:52:07 +00:00
d3548eb706
* Rebased and git-squashed the commits in PR #6546 migrate abci to finalizeBlock work on abci, proxy and mempool abciresponse, blok events, indexer, some tests fix some tests fix errors fix errors in abci fix tests amd errors * Fixes after rebasing PR#6546 * Restored height to RequestFinalizeBlock & other * Fixed more UTs * Fixed kvstore * More UT fixes * last TC fixed * make format * Update internal/consensus/mempool_test.go Co-authored-by: William Banfield <4561443+williambanfield@users.noreply.github.com> * Addressed @williambanfield's comments * Fixed UTs * Addressed last comments from @williambanfield * make format Co-authored-by: marbar3778 <marbar3778@yahoo.com> Co-authored-by: William Banfield <4561443+williambanfield@users.noreply.github.com>
37 lines
969 B
Go
37 lines
969 B
Go
package p2p_test
|
|
|
|
import (
|
|
"bytes"
|
|
"encoding/hex"
|
|
"testing"
|
|
|
|
"github.com/stretchr/testify/require"
|
|
|
|
"github.com/tendermint/tendermint/internal/p2p"
|
|
"github.com/tendermint/tendermint/libs/log"
|
|
"github.com/tendermint/tendermint/types"
|
|
)
|
|
|
|
// Transports are mainly tested by common tests in transport_test.go, we
|
|
// register a transport factory here to get included in those tests.
|
|
func init() {
|
|
var network *p2p.MemoryNetwork // shared by transports in the same test
|
|
|
|
testTransports["memory"] = func(t *testing.T) p2p.Transport {
|
|
if network == nil {
|
|
network = p2p.NewMemoryNetwork(log.TestingLogger(), 1)
|
|
}
|
|
i := byte(network.Size())
|
|
nodeID, err := types.NewNodeID(hex.EncodeToString(bytes.Repeat([]byte{i<<4 + i}, 20)))
|
|
require.NoError(t, err)
|
|
transport := network.CreateTransport(nodeID)
|
|
|
|
t.Cleanup(func() {
|
|
require.NoError(t, transport.Close())
|
|
network = nil // set up a new memory network for the next test
|
|
})
|
|
|
|
return transport
|
|
}
|
|
}
|