From 139a26705abe012ca4a93b9522bb5383d9496409 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=BB=84=E6=80=9D=E6=95=8F?= Date: Fri, 26 Aug 2022 11:00:18 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B5=8B=E8=AF=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- device.go | 5 ++--- rpc.go | 1 - 2 files changed, 2 insertions(+), 4 deletions(-) diff --git a/device.go b/device.go index 5242478..3ba3255 100644 --- a/device.go +++ b/device.go @@ -236,12 +236,11 @@ func (nc *NetCard) runRead() { func (nc *NetCard) runWrite() { var ifce *water.Interface = nc.ifce var err error - var buf = bytes.NewBuffer(nil) + for wframe := range nc.FrameChan { log.Printf("get wframes bytes len: %d", len(wframe)) - buf.Reset() - buf.Write(wframe) + var buf = bytes.NewBuffer(wframe) // zdec, err := zstd.NewReader(buf) // if err != nil { diff --git a/rpc.go b/rpc.go index 4fba933..28e30bd 100644 --- a/rpc.go +++ b/rpc.go @@ -44,7 +44,6 @@ func (s *RPCServer) SendFrames(stream gen.FrameService_SendFramesServer) error { log.Panic(err) } log.Printf("request: %v", len(request.Frames)) - s.netCard.FrameChan <- request.GetFrames() // 接受数据 广播到网卡上 }