Fixed acknowledgement logic in dmsg.Transport's Read method.

skycoin · Jun 19, 2019 · ab70929 · ab70929
1 parent 4cfde04
commit ab70929
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/dmsg/transport.go b/pkg/dmsg/transport.go
@@ -307,7 +307,7 @@ func (tp *Transport) Read(p []byte) (n int, err error) {
 startRead:
 	tp.bufMx.Lock()
 	n, err = tp.buf.Read(p)
-	if tp.bufSize -= n; tp.bufSize < tpBufCap {
+	if tp.bufSize -= n; tp.bufSize < tpBufCap && len(tp.ackBuf) > 0 {
 		acks := tp.ackBuf
 		tp.ackBuf = make([]byte, 0, tpAckCap)
 		go func() {