From fe1ddb0b145f0e4ef5a93e73e09f22ad8a3be180 Mon Sep 17 00:00:00 2001 From: Janos Guljas Date: Thu, 10 Jan 2019 10:29:25 +0100 Subject: [PATCH] p2p/simulations: remove unused triggerChecks func and fix linter --- p2p/simulations/network.go | 37 ------------------------------------- 1 file changed, 37 deletions(-) diff --git a/p2p/simulations/network.go b/p2p/simulations/network.go index ffbc523f6d..86f7dc9bef 100644 --- a/p2p/simulations/network.go +++ b/p2p/simulations/network.go @@ -80,43 +80,6 @@ func (net *Network) Events() *event.Feed { return &net.events } -func triggerChecks(trigger chan enode.ID, net *Network, id enode.ID) error { - node := net.GetNode(id) - if node == nil { - return fmt.Errorf("unknown node: %s", id) - } - client, err := node.Client() - if err != nil { - return err - } - events := make(chan *p2p.PeerEvent) - sub, err := client.Subscribe(context.Background(), "admin", events, "peerEvents") - if err != nil { - return fmt.Errorf("error getting peer events for node %v: %s", id, err) - } - go func() { - defer sub.Unsubscribe() - - tick := time.NewTicker(time.Second) - defer tick.Stop() - - for { - select { - case <-events: - trigger <- id - case <-tick.C: - trigger <- id - case err := <-sub.Err(): - if err != nil { - log.Error(fmt.Sprintf("error getting peer events for node %v", id), "err", err) - } - return - } - } - }() - return nil -} - // NewNodeWithConfig adds a new node to the network with the given config, // returning an error if a node with the same ID or name already exists func (net *Network) NewNodeWithConfig(conf *adapters.NodeConfig) (*Node, error) {