diff --git a/node/node_test.go b/node/node_test.go index f60533540bd..7f1e0fa0cb6 100644 --- a/node/node_test.go +++ b/node/node_test.go @@ -401,12 +401,3 @@ func TestLifecycleTerminationGuarantee(t *testing.T) { delete(stopped, id) } } - -func containsProtocol(stackProtocols []p2p.Protocol, protocol p2p.Protocol) bool { - for _, a := range stackProtocols { - if reflect.DeepEqual(a, protocol) { - return true - } - } - return false -} diff --git a/node/privateapi/mining.go b/node/privateapi/mining.go index 20e9ad4ac3a..48129a60bcd 100644 --- a/node/privateapi/mining.go +++ b/node/privateapi/mining.go @@ -162,10 +162,9 @@ func (s *MiningServer) BroadcastMinedBlock(block *types.Block) error { // MinedBlockStreams - it's safe to use this class as non-pointer type MinedBlockStreams struct { - chans map[uint]txpoolproto.Mining_OnMinedBlockServer - id uint - mu sync.Mutex - logger log.Logger + chans map[uint]txpoolproto.Mining_OnMinedBlockServer + id uint + mu sync.Mutex } func (s *MinedBlockStreams) Add(stream txpoolproto.Mining_OnMinedBlockServer) (remove func()) {