From 99869aa8b89ed5f059f3ecdccb61dcf94090760e Mon Sep 17 00:00:00 2001 From: Dmitriy Ryajov Date: Wed, 25 Sep 2019 12:41:57 -0600 Subject: [PATCH] don't reset buffer on exception --- libp2p/connection.nim | 1 - libp2p/muxers/mplex/coder.nim | 2 +- 2 files changed, 1 insertion(+), 2 deletions(-) diff --git a/libp2p/connection.nim b/libp2p/connection.nim index e7dd07f42..460a0fc1f 100644 --- a/libp2p/connection.nim +++ b/libp2p/connection.nim @@ -100,7 +100,6 @@ proc readLp*(s: Connection): Future[seq[byte]] {.async, gcsafe.} = await s.readExactly(addr buffer[0], int(size)) except LPStreamIncompleteError, LPStreamReadError: error "readLp: could not read from remote", exception = getCurrentExceptionMsg() - buffer.setLen(0) result = buffer diff --git a/libp2p/muxers/mplex/coder.nim b/libp2p/muxers/mplex/coder.nim index b616e3598..acf4f9c3c 100644 --- a/libp2p/muxers/mplex/coder.nim +++ b/libp2p/muxers/mplex/coder.nim @@ -41,7 +41,7 @@ proc readMplexVarint(conn: Connection): Future[Option[uint]] {.async, gcsafe.} = buffer.setLen(0) return except LPStreamIncompleteError: - buffer.setLen(0) + debug "unable to read varing", exc = getCurrentExceptionMsg() proc readMsg*(conn: Connection): Future[Option[Msg]] {.async, gcsafe.} = let headerVarint = await conn.readMplexVarint()