From 21cfcc0bc293581cd782a96d7a2a3d0f1e152022 Mon Sep 17 00:00:00 2001 From: Zack Scholl Date: Wed, 26 Sep 2018 10:53:47 -0700 Subject: [PATCH] use netconn --- src/comm/comm.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/comm/comm.go b/src/comm/comm.go index 4e7966c2..42056402 100644 --- a/src/comm/comm.go +++ b/src/comm/comm.go @@ -25,7 +25,7 @@ func New(n net.Conn) *Comm { c.connection.SetDeadline(time.Now().Add(3 * time.Hour)) c.connection.SetWriteDeadline(time.Now().Add(3 * time.Hour)) c.writer = bufio.NewWriter(n) - c.reader = bufio.NewReader(n) + c.connection = bufio.NewReader(n) return c } @@ -60,7 +60,7 @@ func (c *Comm) Write(b []byte) (int, error) { func (c *Comm) Read() (buf []byte, numBytes int, bs []byte, err error) { // read until we get 6 bytes tmp := make([]byte, 6) - n, err := c.reader.Read(tmp) + n, err := c.connection.Read(tmp) if err != nil { return } @@ -76,7 +76,7 @@ func (c *Comm) Read() (buf []byte, numBytes int, bs []byte, err error) { if len(bs) == 6 { break } - n, err := c.reader.Read(tmp) + n, err := c.connection.Read(tmp) if err != nil { return nil, 0, nil, err }