Clean up NetAddress

tm2/pkg/p2p/base_reactor.go

@@ -47,10 +47,10 @@ type Reactor interface {
  Receive(chID byte, peer Peer, msgBytes []byte)
 }
 
-//--------------------------------------
+// --------------------------------------
 
 type BaseReactor struct {
- service.BaseService // Provides Start, Stop, .Quit
+ service.BaseService // Provides Start, Stop, Quit
  Switch *Switch
 }
 

tm2/pkg/p2p/conn/conn.go

@@ -0,0 +1,22 @@
+package conn
+
+import (
+ "net"
+ "time"
+)
+
+// pipe wraps the networking conn interface
+type pipe struct {
+ net.Conn
+}
+
+func (p *pipe) SetDeadline(_ time.Time) error {
+ return nil
+}
+
+func NetPipe() (net.Conn, net.Conn) {
+ p1, p2 := net.Pipe()
+ return &pipe{p1}, &pipe{p2}
+}
+
+var _ net.Conn = (*pipe)(nil)

tm2/pkg/p2p/mock/peer.go

@@ -25,7 +25,7 @@ func NewPeer(ip net.IP) *Peer {
  if ip == nil {
  _, netAddr = p2p.CreateRoutableAddr()
  } else {
- netAddr = p2p.NewNetAddressFromIPPort("", ip, 26656)
+ netAddr = p2p.NewNetAddressFromIPPort(ip, 26656)
  }
  nodeKey := p2p.NodeKey{PrivKey: ed25519.GenPrivKey()}
  netAddr.ID = nodeKey.ID()