diff --git a/internal/netconn/pktpipe.go b/internal/netconn/pktpipe.go index 5841aa7..09ea9b2 100644 --- a/internal/netconn/pktpipe.go +++ b/internal/netconn/pktpipe.go @@ -35,15 +35,15 @@ func PacketPipe(mtu, queue int) (net.PacketConn, net.PacketConn) { toA := make(chan *[]byte, queue) toB := make(chan *[]byte, queue) - a := &packetPipe{local: "pipe:a", remote: "pipe:b", rx: toA, tx: toB, mtu: mtu, pool: pool, done: make(chan struct{})} - b := &packetPipe{local: "pipe:b", remote: "pipe:a", rx: toB, tx: toA, mtu: mtu, pool: pool, done: make(chan struct{})} + a := &packetPipe{local: pipeAddr("pipe:a"), remote: pipeAddr("pipe:b"), rx: toA, tx: toB, mtu: mtu, pool: pool, done: make(chan struct{})} + b := &packetPipe{local: pipeAddr("pipe:b"), remote: pipeAddr("pipe:a"), rx: toB, tx: toA, mtu: mtu, pool: pool, done: make(chan struct{})} a.peer, b.peer = b, a return a, b } type packetPipe struct { - local pipeAddr - remote pipeAddr + local net.Addr + remote net.Addr rx <-chan *[]byte tx chan<- *[]byte peer *packetPipe