From b1cbafda736b5efbb607b602379f13a487104f5d Mon Sep 17 00:00:00 2001 From: samosvalishe Date: Tue, 22 Sep 2026 20:04:05 +0300 Subject: [PATCH] =?UTF-8?q?perf(netconn):=20=D0=B0=D0=B4=D1=80=D0=B5=D1=81?= =?UTF-8?q?=20=D0=BF=D0=B0=D0=B9=D0=BF=D0=B0=20=D0=B1=D0=B5=D0=B7=20=D0=B0?= =?UTF-8?q?=D0=BB=D0=BB=D0=BE=D0=BA=D0=B0=D1=86=D0=B8=D0=B8=20=D0=BD=D0=B0?= =?UTF-8?q?=20=D0=BA=D0=B0=D0=B6=D0=B4=D0=BE=D0=B5=20=D1=87=D1=82=D0=B5?= =?UTF-8?q?=D0=BD=D0=B8=D0=B5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- internal/netconn/pktpipe.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) 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