diff --git a/internal/blocksync/v0/pool.go b/internal/blocksync/pool.go similarity index 99% rename from internal/blocksync/v0/pool.go rename to internal/blocksync/pool.go index b3704f333..d10a32b0d 100644 --- a/internal/blocksync/v0/pool.go +++ b/internal/blocksync/pool.go @@ -1,4 +1,4 @@ -package v0 +package blocksync import ( "errors" diff --git a/internal/blocksync/v0/pool_test.go b/internal/blocksync/pool_test.go similarity index 99% rename from internal/blocksync/v0/pool_test.go rename to internal/blocksync/pool_test.go index 67617d2b7..cbe19acbe 100644 --- a/internal/blocksync/v0/pool_test.go +++ b/internal/blocksync/pool_test.go @@ -1,4 +1,4 @@ -package v0 +package blocksync import ( "fmt" diff --git a/internal/blocksync/v0/reactor.go b/internal/blocksync/reactor.go similarity index 99% rename from internal/blocksync/v0/reactor.go rename to internal/blocksync/reactor.go index 552dcbda5..0c193577e 100644 --- a/internal/blocksync/v0/reactor.go +++ b/internal/blocksync/reactor.go @@ -1,4 +1,4 @@ -package v0 +package blocksync import ( "fmt" @@ -6,7 +6,6 @@ import ( "sync" "time" - "github.com/tendermint/tendermint/internal/blocksync" "github.com/tendermint/tendermint/internal/consensus" "github.com/tendermint/tendermint/internal/p2p" sm "github.com/tendermint/tendermint/internal/state" @@ -36,7 +35,7 @@ var ( Priority: 5, SendQueueCapacity: 1000, RecvBufferCapacity: 1024, - RecvMessageCapacity: blocksync.MaxMsgSize, + RecvMessageCapacity: MaxMsgSize, MaxSendBytes: 100, }, }, diff --git a/internal/blocksync/v0/reactor_test.go b/internal/blocksync/reactor_test.go similarity index 99% rename from internal/blocksync/v0/reactor_test.go rename to internal/blocksync/reactor_test.go index 312b1cb39..3824f1460 100644 --- a/internal/blocksync/v0/reactor_test.go +++ b/internal/blocksync/reactor_test.go @@ -1,4 +1,4 @@ -package v0 +package blocksync import ( "os" diff --git a/node/setup.go b/node/setup.go index ebaa576c2..a3491c995 100644 --- a/node/setup.go +++ b/node/setup.go @@ -12,7 +12,7 @@ import ( abciclient "github.com/tendermint/tendermint/abci/client" "github.com/tendermint/tendermint/config" "github.com/tendermint/tendermint/crypto" - bcv0 "github.com/tendermint/tendermint/internal/blocksync/v0" + "github.com/tendermint/tendermint/internal/blocksync" "github.com/tendermint/tendermint/internal/consensus" "github.com/tendermint/tendermint/internal/evidence" "github.com/tendermint/tendermint/internal/mempool" @@ -310,13 +310,13 @@ func createBlockchainReactor( logger = logger.With("module", "blockchain") - reactorShim := p2p.NewReactorShim(logger, "BlockchainShim", bcv0.ChannelShims) - channels := makeChannelsFromShims(router, bcv0.ChannelShims) + reactorShim := p2p.NewReactorShim(logger, "BlockchainShim", blocksync.ChannelShims) + channels := makeChannelsFromShims(router, blocksync.ChannelShims) peerUpdates := peerManager.Subscribe() - reactor, err := bcv0.NewReactor( + reactor, err := blocksync.NewReactor( logger, state.Copy(), blockExec, blockStore, csReactor, - channels[bcv0.BlockSyncChannel], peerUpdates, blockSync, + channels[blocksync.BlockSyncChannel], peerUpdates, blockSync, metrics, ) if err != nil { @@ -512,7 +512,7 @@ func makeNodeInfo( txIndexerStatus = "on" } - bcChannel := byte(bcv0.BlockSyncChannel) + bcChannel := byte(blocksync.BlockSyncChannel) nodeInfo := types.NodeInfo{ ProtocolVersion: types.ProtocolVersion{