|
@ -7,6 +7,7 @@ import ( |
|
|
"sync/atomic" |
|
|
"sync/atomic" |
|
|
"time" |
|
|
"time" |
|
|
|
|
|
|
|
|
|
|
|
"github.com/op/go-logging" |
|
|
. "github.com/tendermint/tendermint/binary" |
|
|
. "github.com/tendermint/tendermint/binary" |
|
|
. "github.com/tendermint/tendermint/common" |
|
|
. "github.com/tendermint/tendermint/common" |
|
|
) |
|
|
) |
|
@ -190,7 +191,7 @@ func (c *Connection) recvHandler() { |
|
|
|
|
|
|
|
|
FOR_LOOP: |
|
|
FOR_LOOP: |
|
|
for { |
|
|
for { |
|
|
if true { |
|
|
|
|
|
|
|
|
if log.IsEnabledFor(logging.DEBUG) { |
|
|
// peeking into bufReader
|
|
|
// peeking into bufReader
|
|
|
numBytes := c.bufReader.Buffered() |
|
|
numBytes := c.bufReader.Buffered() |
|
|
bytes, err := c.bufReader.Peek(MinInt(numBytes, 100)) |
|
|
bytes, err := c.bufReader.Peek(MinInt(numBytes, 100)) |
|
|