From cb522f2f06ce1901f3d8392f96af649c2057fc84 Mon Sep 17 00:00:00 2001 From: Zack Scholl Date: Wed, 22 Apr 2020 06:24:47 -0700 Subject: [PATCH] debugging the comm --- src/comm/comm.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/src/comm/comm.go b/src/comm/comm.go index 8e922d6..e3cc68f 100644 --- a/src/comm/comm.go +++ b/src/comm/comm.go @@ -83,6 +83,7 @@ func (c *Comm) Read() (buf []byte, numBytes int, bs []byte, err error) { n, errRead := c.connection.Read(tmp) if errRead != nil { err = errRead + logger.Debug("initial read error: %s", err.Error()) return } header = append(header, tmp[:n]...) @@ -96,6 +97,7 @@ func (c *Comm) Read() (buf []byte, numBytes int, bs []byte, err error) { err = binary.Read(rbuf, binary.LittleEndian, &numBytesUint32) if err != nil { err = fmt.Errorf("binary.Read failed: %s", err.Error()) + logger.Debug(err.Error()) return } numBytes = int(numBytesUint32) @@ -114,6 +116,7 @@ func (c *Comm) Read() (buf []byte, numBytes int, bs []byte, err error) { n, errRead := c.connection.Read(tmp) if errRead != nil { err = errRead + logger.Debug("consecutive read error: %s", err.Error()) return } buf = append(buf, tmp[:n]...)