mirror of
https://github.com/ethereum/go-ethereum.git
synced 2026-08-20 10:52:25 +00:00
p2p/simulations/adapters: adapt to new NodeDialer interface
This commit is contained in:
parent
0c3cd1a461
commit
613ef8db02
1 changed files with 2 additions and 1 deletions
|
|
@ -17,6 +17,7 @@
|
||||||
package adapters
|
package adapters
|
||||||
|
|
||||||
import (
|
import (
|
||||||
|
"context"
|
||||||
"errors"
|
"errors"
|
||||||
"fmt"
|
"fmt"
|
||||||
"math"
|
"math"
|
||||||
|
|
@ -126,7 +127,7 @@ func (s *SimAdapter) NewNode(config *NodeConfig) (Node, error) {
|
||||||
|
|
||||||
// Dial implements the p2p.NodeDialer interface by connecting to the node using
|
// Dial implements the p2p.NodeDialer interface by connecting to the node using
|
||||||
// an in-memory net.Pipe
|
// an in-memory net.Pipe
|
||||||
func (s *SimAdapter) Dial(dest *enode.Node) (conn net.Conn, err error) {
|
func (s *SimAdapter) Dial(ctx context.Context, dest *enode.Node) (conn net.Conn, err error) {
|
||||||
node, ok := s.GetNode(dest.ID())
|
node, ok := s.GetNode(dest.ID())
|
||||||
if !ok {
|
if !ok {
|
||||||
return nil, fmt.Errorf("unknown node: %s", dest.ID())
|
return nil, fmt.Errorf("unknown node: %s", dest.ID())
|
||||||
|
|
|
||||||
Loading…
Reference in a new issue